MainDbService.cs 57 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276
  1. using Dapper;
  2. using EVCB_OCPP.Domain;
  3. using EVCB_OCPP.Domain.ConnectionFactory;
  4. using EVCB_OCPP.Domain.Models.MainDb;
  5. using EVCB_OCPP.Packet.Features;
  6. using EVCB_OCPP.Packet.Messages.Core;
  7. using EVCB_OCPP.Packet.Messages.FirmwareManagement;
  8. using EVCB_OCPP.Packet.Messages.LocalAuthListManagement;
  9. using EVCB_OCPP.Packet.Messages.RemoteTrigger;
  10. using EVCB_OCPP.Packet.Messages.Reservation;
  11. using EVCB_OCPP.Packet.Messages.Security;
  12. using EVCB_OCPP.Packet.Messages.SmartCharging;
  13. using EVCB_OCPP.WSServer.Helper;
  14. using Microsoft.Data.SqlClient;
  15. using Microsoft.EntityFrameworkCore;
  16. using Microsoft.Extensions.Caching.Memory;
  17. using Microsoft.Extensions.Configuration;
  18. using Microsoft.Extensions.Logging;
  19. using Newtonsoft.Json;
  20. using OCPPPackage.Profiles;
  21. using System.Data;
  22. namespace EVCB_OCPP.WSServer.Service.DbService;
  23. public interface IMainDbService
  24. {
  25. Task<string> GetMachineAuthorizationKey(string ChargeBoxId, CancellationToken token = default);
  26. Task<string> GetMachineConfiguration(string ChargeBoxId, string configName, CancellationToken token = default);
  27. Task<string> GetMachineHeartbeatInterval(string ChargeBoxId);
  28. Task<MachineAndCustomerInfo> GetMachineIdAndCustomerInfo(string ChargeBoxId, CancellationToken token = default);
  29. Task<string> GetMachineSecurityProfile(string ChargeBoxId, CancellationToken token = default);
  30. Task UpdateMachineBasicInfo(string ChargeBoxId, Machine machine);
  31. Task AddOCMF(Ocmf oCMF);
  32. ValueTask<ConnectorStatus> GetConnectorStatus(string ChargeBoxId, int ConnectorId);
  33. Task UpdateConnectorStatus(string Id, ConnectorStatus connectorStatus);
  34. ValueTask AddConnectorStatus(string ChargeBoxId, byte ConnectorId, DateTime CreatedOn, int Status,
  35. int ChargePointErrorCodeId, string ErrorInfo, string VendorId, string VendorErrorCode);
  36. Task<string> AddServerMessage(ServerMessage message);
  37. Task<string> AddServerMessage(string ChargeBoxId, string OutAction, object OutRequest, string CreatedBy = "", DateTime? CreatedOn = null, string SerialNo = "", string InMessage = "");
  38. ValueTask AddMachineError(byte ConnectorId, DateTime CreatedOn, int Status, string ChargeBoxId, int ErrorCodeId, string ErrorInfo, int PreStatus, string VendorErrorCode, string VendorId);
  39. ValueTask FillupFinishedTimetoMachineError(byte ConnectorId, DateTime FinishedOn, string ChargeBoxId);
  40. ValueTask<Customer> GetCustomer(string id, CancellationToken token = default);
  41. ValueTask<Customer> GetCustomer(Guid id, CancellationToken token = default);
  42. Task<Guid> GetCustomerIdByChargeBoxId(string chargeboxId);
  43. Task<int?> TryGetDuplicatedTransactionId(string chargeBoxId, Guid customerId, int connectorId, DateTime timestamp);
  44. Task<int> AddNewTransactionRecord(TransactionRecord newTransaction);
  45. Task<TransactionRecord> GetTransactionForStopTransaction(int transactionId, string chargeBoxId);
  46. Task UpdateTransaction(int transactionId, int meterStop, DateTime stopTime, int stopReasonId, string stopReason, string stopIdTag, string receipt, int cost);
  47. Task<bool> UpdateHeartBeats(IEnumerable<Machine> heartBeatsData);
  48. Task<bool> UpdateHeartBeats(List<string> machineIds);
  49. Task UpdateTransactionSOC(int id, string startsoc, string stopsoc);
  50. Task UpdateMachineConnectionType(string chargeBoxId, int v);
  51. Task<string> GetMachineConnectorType(string chargeBoxId, CancellationToken token = default);
  52. Task SetMachineConnectionType(string chargeBoxId, int connectionType, CancellationToken token = default);
  53. Task UpdateServerMessageUpdateTime(int table_id);
  54. Task AddMachineConfiguration(string chargeBoxId, string key, string value, bool isReadOnly, bool isExist = true);
  55. Task UpdateMachineConfiguration(string chargeBoxId, string item, string empty, bool isReadOnly, bool isExists = true);
  56. Task<List<MachineConfigurations>> GetMachineConfiguration(string chargeBoxId);
  57. Task<object> TryGetResponseFromDb(string msgId, CancellationToken token = default);
  58. }
  59. public class MainDbService : IMainDbService
  60. {
  61. public MainDbService(
  62. IDbContextFactory<MainDBContext> contextFactory,
  63. ISqlConnectionFactory<MainDBContext> sqlConnectionFactory,
  64. IMemoryCache memoryCache,
  65. IConfiguration configuration,
  66. ILoggerFactory loggerFactory,
  67. ILogger<MainDbService> logger)
  68. {
  69. this.contextFactory = contextFactory;
  70. this.sqlConnectionFactory = sqlConnectionFactory;
  71. this.memoryCache = memoryCache;
  72. this.loggerFactory = loggerFactory;
  73. this.logger = logger;
  74. var startupLimit = GetStartupLimit(configuration);
  75. //this.connectionString = configuration.GetConnectionString("MainDBContext");
  76. startupSemaphore = new(startupLimit);
  77. var opLimit = GetOpLimit(configuration);
  78. opSemaphore = new SemaphoreSlim(opLimit);
  79. InitUpdateConnectorStatusHandler();
  80. InitUpdateMachineBasicInfoHandler();
  81. InitAddServerMessageHandler();
  82. InitUpdateServerMessageUpdateOnHandler();
  83. InitGetMachineConfigurationHandler();
  84. }
  85. private const string CustomerMemCacheKeyFromat = "Customer_{0}";
  86. //private const string ChargeBoxConnectorIdMemCacheKeyFromat = "Connector_{0}{1}";
  87. private readonly IDbContextFactory<MainDBContext> contextFactory;
  88. private readonly ISqlConnectionFactory<MainDBContext> sqlConnectionFactory;
  89. private readonly IMemoryCache memoryCache;
  90. private readonly ILoggerFactory loggerFactory;
  91. private readonly ILogger<MainDbService> logger;
  92. //private string connectionString;
  93. private readonly QueueSemaphore startupSemaphore;
  94. private readonly SemaphoreSlim opSemaphore;
  95. private GroupHandler<StatusNotificationParam> statusNotificationHandler;
  96. private GroupHandler<UpdateMachineBasicInfoParam> updateMachineBasicInfoHandler;
  97. private GroupHandler<ServerMessage, string> addServerMessageHandler;
  98. private GroupHandler<int> updateServerMessageUpdateOnHandler;
  99. private GroupHandler<string, List<MachineConfigurations>> getMachineConfigurationHandler;
  100. public async Task<MachineAndCustomerInfo> GetMachineIdAndCustomerInfo(string ChargeBoxId, CancellationToken token = default)
  101. {
  102. using var semaphoreWrapper = await startupSemaphore.GetToken();
  103. using var db = await contextFactory.CreateDbContextAsync(token);
  104. var machine = await db.Machine.Where(x => x.ChargeBoxId == ChargeBoxId && x.IsDelete == false).Select(x => new { x.CustomerId, x.Id }).AsNoTracking().FirstOrDefaultAsync(token);
  105. if (machine == null)
  106. {
  107. return new MachineAndCustomerInfo(string.Empty, Guid.Empty, "Unknown");
  108. }
  109. //var customerName = await db.Customer.Where(x => x.Id == machine.CustomerId).Select(x => x.Name).FirstOrDefaultAsync();
  110. var customer = await GetCustomer(machine.CustomerId, token);
  111. var customerName = customer?.Name;
  112. return new MachineAndCustomerInfo(machine.Id, machine.CustomerId, customerName);
  113. }
  114. public Task<List<MachineConfigurations>> GetMachineConfiguration(string chargeBoxId)
  115. {
  116. return getMachineConfigurationHandler.HandleAsync(chargeBoxId);
  117. }
  118. public async Task<string> GetMachineConfiguration(string ChargeBoxId, string configName, CancellationToken token = default)
  119. {
  120. using var semaphoreWrapper = await startupSemaphore.GetToken();
  121. using var db = await contextFactory.CreateDbContextAsync(token);
  122. return await db.MachineConfigurations
  123. .Where(x => x.ChargeBoxId == ChargeBoxId && x.ConfigureName == configName)
  124. .Select(x => x.ConfigureSetting).FirstOrDefaultAsync(token);
  125. }
  126. public Task<string> GetMachineSecurityProfile(string ChargeBoxId, CancellationToken token = default)
  127. {
  128. return GetMachineConfiguration(ChargeBoxId, StandardConfiguration.SecurityProfile, token);
  129. }
  130. public Task<string> GetMachineAuthorizationKey(string ChargeBoxId, CancellationToken token = default)
  131. {
  132. return GetMachineConfiguration(ChargeBoxId, StandardConfiguration.AuthorizationKey, token);
  133. }
  134. public Task<string> GetMachineHeartbeatInterval(string ChargeBoxId)
  135. {
  136. return GetMachineConfiguration(ChargeBoxId, StandardConfiguration.HeartbeatInterval);
  137. }
  138. public Task UpdateMachineBasicInfo(string ChargeBoxId, Machine machine)
  139. {
  140. //return UpdateMachineBasicInfoEF(ChargeBoxId, machine);
  141. return updateMachineBasicInfoHandler.HandleAsync(new UpdateMachineBasicInfoParam(ChargeBoxId, machine));
  142. }
  143. public async Task AddOCMF(Ocmf oCMF)
  144. {
  145. using var db = await contextFactory.CreateDbContextAsync();
  146. await db.Ocmf.AddAsync(oCMF);
  147. await db.SaveChangesAsync();
  148. }
  149. public async ValueTask AddConnectorStatus(
  150. string ChargeBoxId, byte ConnectorId, DateTime CreatedOn, int Status,
  151. int ChargePointErrorCodeId, string ErrorInfo, string VendorId, string VendorErrorCode)
  152. {
  153. using var db = await contextFactory.CreateDbContextAsync();
  154. var _currentStatus = new ConnectorStatus()
  155. {
  156. ChargeBoxId = ChargeBoxId,
  157. ConnectorId = ConnectorId,
  158. CreatedOn = CreatedOn,
  159. Status = Status,
  160. ChargePointErrorCodeId = ChargePointErrorCodeId,
  161. ErrorInfo = ErrorInfo,
  162. VendorId = VendorId,
  163. VendorErrorCode = VendorErrorCode,
  164. Id = Guid.NewGuid().ToString()
  165. };
  166. await db.ConnectorStatus.AddAsync(_currentStatus);
  167. await db.SaveChangesAsync();
  168. //memoryCache.Set(
  169. // string.Format(ChargeBoxConnectorIdMemCacheKeyFromat, ChargeBoxId, ConnectorId)
  170. // , _currentStatus, TimeSpan.FromHours(12));
  171. }
  172. public async ValueTask<ConnectorStatus> GetConnectorStatus(string ChargeBoxId, int ConnectorId)
  173. {
  174. //var key = string.Format(ChargeBoxConnectorIdMemCacheKeyFromat, ChargeBoxId, ConnectorId);
  175. //if (memoryCache.TryGetValue<ConnectorStatus>(key, out var status))
  176. //{
  177. // return status;
  178. //}
  179. using var db = await contextFactory.CreateDbContextAsync();
  180. var statusFromDb = await db.ConnectorStatus.Where(x => x.ChargeBoxId == ChargeBoxId
  181. && x.ConnectorId == ConnectorId).AsNoTracking().FirstOrDefaultAsync();
  182. //memoryCache.Set(key, statusFromDb, TimeSpan.FromHours(12));
  183. return statusFromDb;
  184. }
  185. public async Task UpdateConnectorStatus(string Id, ConnectorStatus Status)
  186. {
  187. //await statusNotificationHandler.HandleAsync(new StatusNotificationParam(Id, Status));
  188. //await UpdateConnectorStatusEF(Id, Status);
  189. await UpdateConnectorStatusDapper(Id, Status);
  190. //var key = string.Format(ChargeBoxConnectorIdMemCacheKeyFromat, Status.ChargeBoxId, Status.ConnectorId);
  191. //memoryCache.Set(key, Status, TimeSpan.FromHours(12));
  192. return;
  193. }
  194. public Task<Guid> GetCustomerIdByChargeBoxId(string chargeboxId)
  195. {
  196. //return GetCustomerIdByChargeBoxIdEF(chargeboxId);
  197. return GetCustomerIdByChargeBoxIdDapper(chargeboxId);
  198. }
  199. public Task<int?> TryGetDuplicatedTransactionId(string chargeBoxId, Guid customerId, int connectorId, DateTime timestamp)
  200. {
  201. //return TryGetDuplicatedTransactionIdEF(chargeBoxId, customerId, connectorId, timestamp);
  202. return TryGetDuplicatedTransactionIdDapper(chargeBoxId, customerId, connectorId, timestamp);
  203. }
  204. public ValueTask AddMachineError(byte ConnectorId, DateTime CreatedOn, int Status, string ChargeBoxId,
  205. int ErrorCodeId, string ErrorInfo, int PreStatus, string VendorErrorCode, string VendorId)
  206. {
  207. //return AddMachineErrorEF(ConnectorId, CreatedOn, Status, ChargeBoxId, ErrorCodeId, ErrorInfo, PreStatus, VendorErrorCode, VendorId);
  208. return AddMachineErrorDapper(ConnectorId, CreatedOn, Status, ChargeBoxId, ErrorCodeId, ErrorInfo, PreStatus, VendorErrorCode, VendorId);
  209. }
  210. public ValueTask FillupFinishedTimetoMachineError(byte ConnectorId, DateTime FinishedOn, string ChargeBoxId)
  211. {
  212. return AddFinishedTimetoMachineErrorDapper(ConnectorId, FinishedOn, ChargeBoxId);
  213. }
  214. public async Task<string> AddServerMessage(string ChargeBoxId, string OutAction, object OutRequest, string CreatedBy, DateTime? CreatedOn = null, string SerialNo = "", string InMessage = "")
  215. {
  216. if (string.IsNullOrEmpty(CreatedBy))
  217. {
  218. CreatedBy = "Server";
  219. }
  220. if (string.IsNullOrEmpty(SerialNo))
  221. {
  222. SerialNo = Guid.NewGuid().ToString();
  223. }
  224. var _CreatedOn = CreatedOn ?? DateTime.UtcNow;
  225. string _OutRequest = "";
  226. if (OutRequest is not null)
  227. {
  228. _OutRequest = JsonConvert.SerializeObject(
  229. OutRequest,
  230. new JsonSerializerSettings()
  231. {
  232. NullValueHandling = NullValueHandling.Ignore,
  233. Formatting = Formatting.None
  234. });
  235. }
  236. var data = new ServerMessage()
  237. {
  238. ChargeBoxId = ChargeBoxId,
  239. CreatedBy = CreatedBy,
  240. CreatedOn = _CreatedOn,
  241. OutAction = OutAction,
  242. OutRequest = _OutRequest,
  243. SerialNo = SerialNo,
  244. InMessage = InMessage
  245. };
  246. await AddServerMessage(data);
  247. return SerialNo;
  248. }
  249. public Task<string> AddServerMessage(ServerMessage message)
  250. {
  251. //return AddServerMessageEF(message);
  252. return addServerMessageHandler.HandleAsync(message);
  253. //var id = message.SerialNo;
  254. //await AddServerMessageDapper(message);
  255. //return id;
  256. }
  257. public ValueTask<Customer> GetCustomer(string id, CancellationToken token = default)
  258. => GetCustomer(new Guid(id), token);
  259. public async ValueTask<Customer> GetCustomer(Guid id, CancellationToken token = default)
  260. {
  261. var key = string.Format(CustomerMemCacheKeyFromat, id);
  262. if (memoryCache.TryGetValue<Customer>(key, out var customer))
  263. {
  264. return customer;
  265. }
  266. Customer toReturn = null;
  267. using (var db = await contextFactory.CreateDbContextAsync(token))
  268. {
  269. toReturn = await db.Customer.FirstOrDefaultAsync(x => x.Id == id, token);
  270. }
  271. if (toReturn is not null)
  272. {
  273. memoryCache.Set(key, toReturn, TimeSpan.FromSeconds(15));
  274. }
  275. return toReturn;
  276. }
  277. public Task<int> AddNewTransactionRecord(TransactionRecord newTransaction)
  278. {
  279. //return AddNewTransactionRecordEF(newTransaction);
  280. return AddNewTransactionRecordDapper(newTransaction);
  281. }
  282. public Task<TransactionRecord> GetTransactionForStopTransaction(int transactionId, string chargeBoxId)
  283. {
  284. //return GetTransactionForStopTransactionEF(transactionId, chargeBoxId);
  285. return GetTransactionForStopTransactionDapper(transactionId, chargeBoxId);
  286. }
  287. public Task UpdateTransaction(int transactionId, int meterStop, DateTime stopTime, int stopReasonId, string stopReason, string stopIdTag, string receipt, int cost)
  288. {
  289. //return UpdateTransactionEF(transactionId, meterStop, stopTime, stopReasonId, stopReason, stopIdTag, receipt, cost);
  290. return UpdateTransactionDapper(transactionId, meterStop, stopTime, stopReasonId, stopReason, stopIdTag, receipt, cost);
  291. }
  292. public async Task UpdateTransactionSOC(int id, string startSOC, string stopSOC)
  293. {
  294. var parameters = new DynamicParameters();
  295. parameters.Add("@TransactionId", id, DbType.Int32, ParameterDirection.Input);
  296. parameters.Add("@StartSOC", startSOC, DbType.String, ParameterDirection.Input, 3);
  297. parameters.Add("@StopSOC", stopSOC, DbType.String, ParameterDirection.Input, 3);
  298. using var conn = await sqlConnectionFactory.CreateAsync();
  299. var resultCnt = await conn.ExecuteAsync("""
  300. UPDATE TransactionRecord
  301. SET StartSOC = @StartSOC, StopSOC = @StopSOC
  302. WHERE Id = @TransactionId
  303. """, parameters);
  304. if (resultCnt != 1)
  305. {
  306. throw new Exception("Update over one columes");
  307. }
  308. return;
  309. }
  310. public Task UpdateServerMessageUpdateTime(int table_id)
  311. {
  312. return updateServerMessageUpdateOnHandler.HandleAsync(table_id);
  313. }
  314. public async Task AddMachineConfiguration(string chargeBoxId, string key, string value, bool isReadOnly, bool isExists = true)
  315. {
  316. using var db = await contextFactory.CreateDbContextAsync();
  317. await db.MachineConfigurations.AddAsync(new MachineConfigurations()
  318. {
  319. ChargeBoxId = chargeBoxId,
  320. ConfigureName = key,
  321. ReadOnly = isReadOnly,
  322. ConfigureSetting = string.IsNullOrEmpty(value) ? string.Empty : value,
  323. Exists = isExists
  324. });
  325. await db.SaveChangesAsync();
  326. }
  327. private async Task UpdateTransactionEF(int transactionId, int meterStop, DateTime stopTime, int stopReasonId, string stopReason, string stopIdTag, string receipt, int cost)
  328. {
  329. using var db = await contextFactory.CreateDbContextAsync();
  330. var _transaction = db.TransactionRecord.Where(x => x.Id == transactionId //&& x.ChargeBoxId == session.ChargeBoxId
  331. ).FirstOrDefault();
  332. _transaction.MeterStop = meterStop;
  333. _transaction.StopTime = stopTime;
  334. _transaction.StopReasonId = stopReasonId;
  335. _transaction.StopReason = stopReason;
  336. _transaction.StopIdTag = stopIdTag;
  337. _transaction.Receipt = receipt;
  338. _transaction.Cost = cost;
  339. //await db.SaveChangesAsync();
  340. await db.SaveChangesAsync();
  341. }
  342. public async Task UpdateMachineConfiguration(string chargeBoxId, string item, string value, bool isReadonly, bool isExists = true)
  343. {
  344. using var db = await contextFactory.CreateDbContextAsync();
  345. var config = await db.MachineConfigurations.FirstOrDefaultAsync(x => x.ChargeBoxId == chargeBoxId && x.ConfigureName == item);
  346. if (config is null)
  347. {
  348. return;
  349. }
  350. config.ConfigureSetting = value;
  351. config.ReadOnly = isReadonly;
  352. config.Exists = isExists;
  353. await db.SaveChangesAsync();
  354. }
  355. private async Task UpdateTransactionDapper(int transactionId, int meterStop, DateTime stopTime, int stopReasonId, string stopReason, string stopIdTag, string receipt, int cost)
  356. {
  357. var parameters = new DynamicParameters();
  358. parameters.Add("@TransactionId", transactionId, DbType.Int32, ParameterDirection.Input);
  359. parameters.Add("@MeterStop", meterStop, DbType.Decimal, ParameterDirection.Input, precision: 18, scale: 2);
  360. parameters.Add("@StopTime", stopTime, DbType.DateTime, ParameterDirection.Input);
  361. parameters.Add("@StopReasonId", stopReasonId, DbType.Int32, ParameterDirection.Input);
  362. parameters.Add("@StopReason", stopReason, DbType.String, ParameterDirection.Input, 60);
  363. parameters.Add("@StopIdTag", stopIdTag, DbType.String, ParameterDirection.Input, 20);
  364. parameters.Add("@Receipt", receipt, DbType.String, ParameterDirection.Input, 3000);
  365. parameters.Add("@Cost", cost, DbType.Decimal, ParameterDirection.Input, precision: 18, scale: 2);
  366. using var conn = await sqlConnectionFactory.CreateAsync();
  367. var resultCnt = await conn.ExecuteAsync("""
  368. UPDATE TransactionRecord
  369. SET MeterStop = @MeterStop, StopTime = @StopTime, StopReasonId = @StopReasonId,
  370. StopReason = @StopReason, StopIdTag = @StopIdTag, Receipt = @Receipt, Cost = @Cost
  371. WHERE Id = @TransactionId
  372. """, parameters);
  373. if (resultCnt != 1)
  374. {
  375. throw new Exception("Update over one columes");
  376. }
  377. return;
  378. }
  379. public Task<bool> UpdateHeartBeats(IEnumerable<Machine> heartBeatsData)
  380. {
  381. //return UpdateHeartBeatsEF(heartBeatsData);
  382. return UpdateHeartBeatsDapper(heartBeatsData);
  383. }
  384. public Task<bool> UpdateHeartBeats(List<string> machineIds)
  385. {
  386. return UpdateHeartBeatsDapper(machineIds);
  387. }
  388. public async Task UpdateMachineConnectionType(string chargeBoxId, int connectionType)
  389. {
  390. using var semaphoreWrapper = await startupSemaphore.GetToken();
  391. using var db = await contextFactory.CreateDbContextAsync();
  392. var machine = await db.Machine.Where(x => x.ChargeBoxId == chargeBoxId).FirstOrDefaultAsync();
  393. if (machine != null)
  394. {
  395. machine.ConnectionType = connectionType;
  396. await db.SaveChangesAsync();
  397. }
  398. }
  399. public async Task<object> TryGetResponseFromDb(string msgId, CancellationToken token = default)
  400. {
  401. var parameters = new DynamicParameters();
  402. parameters.Add("@MID", msgId, DbType.String, size: 36);
  403. parameters.Add("@MT", DateTime.UtcNow.AddSeconds(-5), DbType.DateTime);
  404. var sql = """
  405. SELECT [OutAction],[InMessage]
  406. FROM [ServerMessage]
  407. WHERE [SerialNo] = @MID AND CreatedOn > @MT
  408. """;
  409. using var conn = await sqlConnectionFactory.CreateAsync();
  410. ServerMessage item = null;
  411. item = await conn.QueryFirstOrDefaultAsync<ServerMessage>(new CommandDefinition(sql, parameters: parameters, cancellationToken: token));
  412. Actions action = Actions.None;
  413. if (item is null ||
  414. !Enum.TryParse(item.OutAction, out action))
  415. {
  416. return null;
  417. }
  418. switch (action)
  419. {
  420. case Actions.GetConfiguration:
  421. return JsonConvert.DeserializeObject<GetConfigurationConfirmation>(item.InMessage);
  422. case Actions.ChangeConfiguration:
  423. return JsonConvert.DeserializeObject<ChangeConfigurationConfirmation>(item.InMessage);
  424. case Actions.RemoteStartTransaction:
  425. return JsonConvert.DeserializeObject<RemoteStartTransactionConfirmation>(item.InMessage);
  426. case Actions.RemoteStopTransaction:
  427. return JsonConvert.DeserializeObject<RemoteStopTransactionConfirmation>(item.InMessage);
  428. case Actions.ChangeAvailability:
  429. return JsonConvert.DeserializeObject<ChangeAvailabilityConfirmation>(item.InMessage);
  430. case Actions.ClearCache:
  431. return JsonConvert.DeserializeObject<ClearCacheConfirmation>(item.InMessage);
  432. case Actions.DataTransfer:
  433. return JsonConvert.DeserializeObject<DataTransferConfirmation>(item.InMessage);
  434. case Actions.Reset:
  435. return JsonConvert.DeserializeObject<ResetConfirmation>(item.InMessage);
  436. case Actions.UnlockConnector:
  437. return JsonConvert.DeserializeObject<UnlockConnectorConfirmation>(item.InMessage);
  438. case Actions.TriggerMessage:
  439. return JsonConvert.DeserializeObject<TriggerMessageConfirmation>(item.InMessage);
  440. case Actions.GetDiagnostics:
  441. return JsonConvert.DeserializeObject<GetDiagnosticsConfirmation>(item.InMessage);
  442. case Actions.UpdateFirmware:
  443. return JsonConvert.DeserializeObject<UpdateFirmwareConfirmation>(item.InMessage);
  444. case Actions.GetLocalListVersion:
  445. return JsonConvert.DeserializeObject<GetLocalListVersionConfirmation>(item.InMessage);
  446. case Actions.SendLocalList:
  447. return JsonConvert.DeserializeObject<SendLocalListConfirmation>(item.InMessage);
  448. case Actions.SetChargingProfile:
  449. return JsonConvert.DeserializeObject<SetChargingProfileConfirmation>(item.InMessage);
  450. case Actions.ClearChargingProfile:
  451. return JsonConvert.DeserializeObject<ClearChargingProfileConfirmation>(item.InMessage);
  452. case Actions.GetCompositeSchedule:
  453. return JsonConvert.DeserializeObject<GetCompositeScheduleConfirmation>(item.InMessage);
  454. case Actions.ReserveNow:
  455. return JsonConvert.DeserializeObject<ReserveNowConfirmation>(item.InMessage);
  456. case Actions.CancelReservation:
  457. return JsonConvert.DeserializeObject<CancelReservationConfirmation>(item.InMessage);
  458. case Actions.ExtendedTriggerMessage:
  459. return JsonConvert.DeserializeObject<ExtendedTriggerMessageConfirmation>(item.InMessage);
  460. default:
  461. return null;
  462. }
  463. }
  464. private void InitUpdateConnectorStatusHandler()
  465. {
  466. if (statusNotificationHandler is not null)
  467. {
  468. throw new Exception($"{nameof(InitUpdateConnectorStatusHandler)} should only called once");
  469. }
  470. statusNotificationHandler = new GroupHandler<StatusNotificationParam>(
  471. handleFunc: BundleUpdateConnectorStatusDapper,
  472. logger: loggerFactory.CreateLogger("StatusNotificationHandler"),
  473. workerCnt: 1);
  474. }
  475. private void InitAddServerMessageHandler()
  476. {
  477. if (addServerMessageHandler is not null)
  478. {
  479. throw new Exception($"{nameof(InitAddServerMessageHandler)} should only called once");
  480. }
  481. addServerMessageHandler = new GroupHandler<ServerMessage, string>(
  482. handleFunc: BundleAddServerMessage,
  483. logger: loggerFactory.CreateLogger("AddServerMessageHandler"));
  484. }
  485. private void InitUpdateMachineBasicInfoHandler()
  486. {
  487. if (updateMachineBasicInfoHandler is not null)
  488. {
  489. throw new Exception($"{nameof(InitUpdateMachineBasicInfoHandler)} should only called once");
  490. }
  491. updateMachineBasicInfoHandler = new GroupHandler<UpdateMachineBasicInfoParam>(
  492. handleFunc: BundelUpdateMachineBasicInfo,
  493. logger: loggerFactory.CreateLogger("UpdateMachineBasicInfoHandler"),
  494. workerCnt: 1);
  495. }
  496. private void InitUpdateServerMessageUpdateOnHandler()
  497. {
  498. if (updateServerMessageUpdateOnHandler is not null)
  499. {
  500. throw new Exception($"{nameof(InitUpdateMachineBasicInfoHandler)} should only called once");
  501. }
  502. updateServerMessageUpdateOnHandler = new GroupHandler<int>(
  503. handleFunc: BundelUpdateServerMessageUpdateOn,
  504. logger: loggerFactory.CreateLogger("UpdateServerMessageUpdateOnHandler"),
  505. workerCnt: 10);
  506. }
  507. private void InitGetMachineConfigurationHandler()
  508. {
  509. if (getMachineConfigurationHandler is not null)
  510. {
  511. throw new Exception($"{nameof(InitUpdateMachineBasicInfoHandler)} should only called once");
  512. }
  513. getMachineConfigurationHandler = new GroupHandler<string, List<MachineConfigurations>>(
  514. handleFunc: BundelGetMachineConfiguration,
  515. logger: loggerFactory.CreateLogger("GetMachineConfigurationHandler"),
  516. workerCnt: 10);
  517. }
  518. private async Task UpdateMachineBasicInfoEF(string chargeBoxId, Machine machine)
  519. {
  520. using var semaphoreWrapper = await startupSemaphore.GetToken();
  521. using var db = await contextFactory.CreateDbContextAsync();
  522. var _machine = await db.Machine.FirstOrDefaultAsync(x => x.ChargeBoxId == chargeBoxId);
  523. _machine.ChargeBoxSerialNumber = machine.ChargeBoxSerialNumber;
  524. _machine.ChargePointSerialNumber = machine.ChargePointSerialNumber;
  525. _machine.ChargePointModel = machine.ChargePointModel;
  526. _machine.ChargePointVendor = machine.ChargePointVendor;
  527. _machine.FwCurrentVersion = machine.FwCurrentVersion;
  528. _machine.Iccid = machine.Iccid;
  529. _machine.Imsi = machine.Imsi;
  530. _machine.MeterSerialNumber = machine.MeterSerialNumber;
  531. _machine.MeterType = machine.MeterType;
  532. await db.SaveChangesAsync();
  533. //using var semaphoreWrapper = await startupSemaphore.GetToken();
  534. }
  535. private async Task BundelUpdateMachineBasicInfo(BundleHandlerData<UpdateMachineBasicInfoParam> bundleHandlerData)
  536. {
  537. using var db = await contextFactory.CreateDbContextAsync();
  538. using var trans = await db.Database.BeginTransactionAsync();
  539. var pams = bundleHandlerData.Datas.DistinctBy(x => x.ChargeBoxId);
  540. foreach (var pam in pams)
  541. {
  542. var _machine = db.Machine.FirstOrDefault(x => x.ChargeBoxId == pam.ChargeBoxId);
  543. _machine.ChargeBoxSerialNumber = pam.machine.ChargeBoxSerialNumber;
  544. _machine.ChargePointSerialNumber = pam.machine.ChargePointSerialNumber;
  545. _machine.ChargePointModel = pam.machine.ChargePointModel;
  546. _machine.ChargePointVendor = pam.machine.ChargePointVendor;
  547. _machine.FwCurrentVersion = pam.machine.FwCurrentVersion;
  548. _machine.Iccid = pam.machine.Iccid;
  549. _machine.Imsi = pam.machine.Imsi;
  550. _machine.MeterSerialNumber = pam.machine.MeterSerialNumber;
  551. _machine.MeterType = pam.machine.MeterType;
  552. }
  553. await db.SaveChangesAsync();
  554. await trans.CommitAsync();
  555. bundleHandlerData.CompletedDatas.AddRange(bundleHandlerData.Datas);
  556. }
  557. private async Task BundelUpdateServerMessageUpdateOn(BundleHandlerData<int> bundleHandlerData)
  558. {
  559. var ids = bundleHandlerData.Datas;
  560. var sql = """
  561. UPDATE [dbo].[ServerMessage]
  562. SET UpdatedOn = @DateTimeNow
  563. WHERE Id in @Ids
  564. """;
  565. DynamicParameters parameters = new DynamicParameters();
  566. parameters.Add("DateTimeNow", DateTime.UtcNow, DbType.DateTime);
  567. parameters.Add("Ids", ids);
  568. using SqlConnection sqlConnection = await sqlConnectionFactory.CreateAsync();
  569. var cnt = await sqlConnection.ExecuteAsync(sql, parameters);
  570. if (cnt != 0 || ids.Count == 0)
  571. {
  572. bundleHandlerData.CompletedDatas.AddRange(ids);
  573. }
  574. }
  575. private async Task BundelGetMachineConfiguration(BundleHandlerData<string, List<MachineConfigurations>> bundleHandlerData)
  576. {
  577. var chargeboxIds = bundleHandlerData.Datas;
  578. var sql = """
  579. SELECT [ChargeBoxId], [ConfigureName], [ConfigureSetting], [ReadOnly], [Exists]
  580. FROM [dbo].[MachineConfigurations]
  581. WHERE ChargeBoxId IN @ChargeBoxIds
  582. """;
  583. DynamicParameters parameters = new DynamicParameters();
  584. parameters.Add("@ChargeBoxIds", chargeboxIds, direction: ParameterDirection.Input, size: 25);
  585. using SqlConnection sqlConnection = await sqlConnectionFactory.CreateAsync();
  586. var result = await sqlConnection.QueryAsync<MachineConfigurations>(sql, parameters);
  587. var gReult = result.GroupBy(x => x.ChargeBoxId);
  588. foreach (var g in gReult)
  589. {
  590. var originKey = chargeboxIds.FirstOrDefault(x=> x.ToLower() == g.Key.ToLower());
  591. if (string.IsNullOrEmpty(originKey))
  592. {
  593. continue;
  594. }
  595. bundleHandlerData.AddCompletedData(originKey, g.ToList());
  596. }
  597. var getConfigChargeboxIds = gReult.Select(x => x.Key);
  598. var emptyConfigChargeboxIds = chargeboxIds.Except(getConfigChargeboxIds);
  599. foreach (var chargeboxId in emptyConfigChargeboxIds)
  600. {
  601. bundleHandlerData.AddCompletedData(chargeboxId, new List<MachineConfigurations>());
  602. }
  603. }
  604. private async Task UpdateConnectorStatusEF(string Id, ConnectorStatus Status)
  605. {
  606. using var db = await contextFactory.CreateDbContextAsync();
  607. ConnectorStatus status = new() { Id = Id };
  608. db.ChangeTracker.AutoDetectChangesEnabled = false;
  609. db.ConnectorStatus.Attach(status);
  610. status.CreatedOn = Status.CreatedOn;
  611. status.Status = Status.Status;
  612. status.ChargePointErrorCodeId = Status.ChargePointErrorCodeId;
  613. status.ErrorInfo = Status.ErrorInfo;
  614. status.VendorId = Status.VendorId;
  615. status.VendorErrorCode = Status.VendorErrorCode;
  616. db.Entry(status).Property(x => x.CreatedOn).IsModified = true;
  617. db.Entry(status).Property(x => x.Status).IsModified = true;
  618. db.Entry(status).Property(x => x.ChargePointErrorCodeId).IsModified = true;
  619. db.Entry(status).Property(x => x.ErrorInfo).IsModified = true;
  620. db.Entry(status).Property(x => x.VendorId).IsModified = true;
  621. db.Entry(status).Property(x => x.VendorErrorCode).IsModified = true;
  622. await db.SaveChangesAsync();
  623. }
  624. private async Task UpdateConnectorStatusDapper(string Id, ConnectorStatus Status)
  625. {
  626. var parameters = new DynamicParameters();
  627. parameters.Add("@Id", Id, DbType.String, ParameterDirection.Input, 36);
  628. parameters.Add("@CreatedOn", Status.CreatedOn, DbType.DateTime, ParameterDirection.Input);
  629. parameters.Add("@Status", Status.Status, DbType.Int32, ParameterDirection.Input);
  630. parameters.Add("@ChargePointErrorCodeId", Status.ChargePointErrorCodeId, DbType.Int32, ParameterDirection.Input);
  631. parameters.Add("@ErrorInfo", Status.ErrorInfo, DbType.String, ParameterDirection.Input, 50);
  632. parameters.Add("@VendorId", Status.VendorId, DbType.String, ParameterDirection.Input, 255);
  633. parameters.Add("@VendorErrorCode", Status.VendorErrorCode, DbType.String, ParameterDirection.Input, 100);
  634. using var conn = await sqlConnectionFactory.CreateAsync();
  635. await conn.ExecuteAsync("""
  636. update ConnectorStatus
  637. set
  638. CreatedOn = @CreatedOn,
  639. Status = @Status,
  640. ChargePointErrorCodeId = @ChargePointErrorCodeId,
  641. ErrorInfo = @ErrorInfo,
  642. VendorId = @VendorId,
  643. VendorErrorCode = @VendorErrorCode
  644. where Id = @Id
  645. """, parameters);
  646. }
  647. private async Task<Guid> GetCustomerIdByChargeBoxIdEF(string chargeboxId)
  648. {
  649. using var db = await contextFactory.CreateDbContextAsync();
  650. var _CustomerId = await db.Machine.Where(x => x.ChargeBoxId == chargeboxId).Select(x => x.CustomerId).FirstOrDefaultAsync();
  651. return _CustomerId;
  652. }
  653. private async Task<Guid> GetCustomerIdByChargeBoxIdDapper(string chargeboxId)
  654. {
  655. var parameters = new DynamicParameters();
  656. parameters.Add("@ChargeBoxId", chargeboxId, DbType.String, ParameterDirection.Input, 50);
  657. using var conn = await sqlConnectionFactory.CreateAsync();
  658. var _existedTx = await conn.QueryFirstOrDefaultAsync<Guid>("""
  659. select CustomerId
  660. from dbo.Machine
  661. where
  662. ChargeBoxId = @ChargeBoxId
  663. """, parameters);
  664. return _existedTx;
  665. }
  666. private async Task<int?> TryGetDuplicatedTransactionIdEF(string chargeBoxId, Guid customerId, int connectorId, DateTime timestamp)
  667. {
  668. using var db = await contextFactory.CreateDbContextAsync();
  669. var _existedTx = await db.TransactionRecord.Where(x => x.CustomerId == customerId && x.ChargeBoxId == chargeBoxId
  670. && x.ConnectorId == connectorId && x.StartTime == timestamp).Select(x => x.Id).FirstOrDefaultAsync();
  671. return _existedTx;
  672. }
  673. private async Task<int?> TryGetDuplicatedTransactionIdDapper(string chargeBoxId, Guid customerId, int connectorId, DateTime timestamp)
  674. {
  675. var parameters = new DynamicParameters();
  676. parameters.Add("@ChargeBoxId", chargeBoxId, DbType.String, ParameterDirection.Input, 50);
  677. parameters.Add("@CustomerId", customerId, DbType.Guid, ParameterDirection.Input);
  678. parameters.Add("@ConnectorId", connectorId, DbType.Int16, ParameterDirection.Input);
  679. parameters.Add("@TimeStamp", timestamp, DbType.DateTime, ParameterDirection.Input);
  680. using var conn = await sqlConnectionFactory.CreateAsync();
  681. var _existedTx = await conn.QueryFirstOrDefaultAsync<int?>("""
  682. SELECT Id
  683. FROM dbo.TransactionRecord
  684. WHERE
  685. ChargeBoxId = @ChargeBoxId and
  686. CustomerId = @CustomerId and
  687. ConnectorId = @ConnectorId and
  688. StartTime = @TimeStamp
  689. """, parameters);
  690. return _existedTx;
  691. }
  692. private async ValueTask AddMachineErrorEF(byte connectorId, DateTime createdOn, int status, string chargeBoxId, int errorCodeId, string errorInfo, int preStatus, string vendorErrorCode, string vendorId)
  693. {
  694. using var db = await contextFactory.CreateDbContextAsync();
  695. await db.MachineError.AddAsync(new MachineError()
  696. {
  697. ConnectorId = connectorId,
  698. CreatedOn = createdOn,
  699. Status = status,
  700. ChargeBoxId = chargeBoxId,
  701. ErrorCodeId = errorCodeId,
  702. ErrorInfo = errorInfo,
  703. PreStatus = preStatus,
  704. VendorErrorCode = vendorErrorCode,
  705. VendorId = vendorId
  706. });
  707. await db.SaveChangesAsync();
  708. }
  709. private async ValueTask AddMachineErrorDapper(byte connectorId, DateTime createdOn, int status, string chargeBoxId, int errorCodeId, string errorInfo, int preStatus, string vendorErrorCode, string vendorId)
  710. {
  711. var parameters = new DynamicParameters();
  712. parameters.Add("@ConnectorId", connectorId, DbType.Int16, ParameterDirection.Input);
  713. parameters.Add("@PreStatus", preStatus, DbType.Int32, ParameterDirection.Input);
  714. parameters.Add("@Status", status, DbType.Int32, ParameterDirection.Input);
  715. parameters.Add("@ErrorInfo", errorInfo, DbType.String, ParameterDirection.Input, 50);
  716. parameters.Add("@VendorId", vendorId, DbType.String, ParameterDirection.Input, 255);
  717. parameters.Add("@CreatedOn", createdOn, DbType.DateTime, ParameterDirection.Input);
  718. parameters.Add("@ErrorCodeId", errorCodeId, DbType.Int32, ParameterDirection.Input);
  719. parameters.Add("@VendorErrorCode", vendorErrorCode, DbType.String, ParameterDirection.Input, 100);
  720. parameters.Add("@ChargeBoxId", chargeBoxId, DbType.String, ParameterDirection.Input, 50);
  721. using var conn = await sqlConnectionFactory.CreateAsync();
  722. await conn.ExecuteAsync("""
  723. INSERT INTO MachineError
  724. (ConnectorId, PreStatus, Status, ErrorInfo, VendorId, CreatedOn, ErrorCodeId, VendorErrorCode, ChargeBoxId)
  725. VALUES (@ConnectorId, @PreStatus, @Status, @ErrorInfo, @VendorId, @CreatedOn, @ErrorCodeId, @VendorErrorCode, @ChargeBoxId)
  726. """, parameters);
  727. }
  728. private async ValueTask AddFinishedTimetoMachineErrorDapper(byte connectorId, DateTime finishedTime, string chargeBoxId)
  729. {
  730. var getCommand = """
  731. SELECT Id
  732. FROM [dbo].[MachineError]
  733. where ChargeBoxId=@ChargeBoxId and ConnectorId=@ConnectorId
  734. Order by Id desc
  735. """;
  736. var updateCommand = """
  737. Update MachineError
  738. set FinishedOn=@FinishedOn
  739. where Id=@Id
  740. """;
  741. var parameters = new DynamicParameters();
  742. parameters.Add("@ConnectorId", connectorId, DbType.Int16, ParameterDirection.Input);
  743. parameters.Add("@ChargeBoxId", chargeBoxId, DbType.String, ParameterDirection.Input, 50);
  744. //parameters.Add("@CreatedOn", previousErrorOn, DbType.DateTime, ParameterDirection.Input, 50);
  745. using var conn = await sqlConnectionFactory.CreateAsync();
  746. var recordId = await conn.QueryFirstOrDefaultAsync<int?>(getCommand, parameters);
  747. if (recordId is null)
  748. {
  749. return;
  750. }
  751. parameters = new DynamicParameters();
  752. parameters.Add("@Id", recordId, DbType.Int32, ParameterDirection.Input);
  753. parameters.Add("@FinishedOn", finishedTime, DbType.DateTime, ParameterDirection.Input, 50);
  754. await conn.ExecuteAsync(updateCommand, parameters);
  755. }
  756. private async Task BundleUpdateConnectorStatus(IEnumerable<StatusNotificationParam> statusNotifications)
  757. {
  758. using var db = await contextFactory.CreateDbContextAsync();
  759. using var trans = await db.Database.BeginTransactionAsync();
  760. statusNotifications = statusNotifications.OrderBy(x => x.Status.CreatedOn).DistinctBy(x => x.Id);
  761. foreach (var param in statusNotifications)
  762. {
  763. ConnectorStatus status = new() { Id = param.Id };
  764. //db.ChangeTracker.AutoDetectChangesEnabled = false;
  765. db.ConnectorStatus.Attach(status);
  766. status.CreatedOn = param.Status.CreatedOn;
  767. status.Status = param.Status.Status;
  768. status.ChargePointErrorCodeId = param.Status.ChargePointErrorCodeId;
  769. status.ErrorInfo = param.Status.ErrorInfo;
  770. status.VendorId = param.Status.VendorId;
  771. status.VendorErrorCode = param.Status.VendorErrorCode;
  772. db.Entry(status).Property(x => x.CreatedOn).IsModified = true;
  773. db.Entry(status).Property(x => x.Status).IsModified = true;
  774. db.Entry(status).Property(x => x.ChargePointErrorCodeId).IsModified = true;
  775. db.Entry(status).Property(x => x.ErrorInfo).IsModified = true;
  776. db.Entry(status).Property(x => x.VendorId).IsModified = true;
  777. db.Entry(status).Property(x => x.VendorErrorCode).IsModified = true;
  778. //await db.SaveChangesAsync();
  779. }
  780. await db.SaveChangesAsync();
  781. await trans.CommitAsync();
  782. //db.ChangeTracker.Clear();
  783. }
  784. private async Task BundleUpdateConnectorStatusDapper(BundleHandlerData<StatusNotificationParam> bundleHandlerData)
  785. {
  786. using var conn = await sqlConnectionFactory.CreateAsync();
  787. foreach (var status in bundleHandlerData.Datas)
  788. {
  789. var parameters = new DynamicParameters();
  790. parameters.Add("@Id", status.Id, DbType.String, ParameterDirection.Input, 36);
  791. parameters.Add("@CreatedOn", status.Status.CreatedOn, DbType.DateTime, ParameterDirection.Input);
  792. parameters.Add("@Status", status.Status.Status, DbType.Int32, ParameterDirection.Input);
  793. parameters.Add("@ChargePointErrorCodeId", status.Status.ChargePointErrorCodeId, DbType.Int32, ParameterDirection.Input);
  794. parameters.Add("@ErrorInfo", status.Status.ErrorInfo, DbType.String, ParameterDirection.Input, 50);
  795. parameters.Add("@VendorId", status.Status.VendorId, DbType.String, ParameterDirection.Input, 255);
  796. parameters.Add("@VendorErrorCode", status.Status.VendorErrorCode, DbType.String, ParameterDirection.Input, 100);
  797. await conn.ExecuteAsync("""
  798. update ConnectorStatus
  799. set
  800. CreatedOn = @CreatedOn,
  801. Status = @Status,
  802. ChargePointErrorCodeId = @ChargePointErrorCodeId,
  803. ErrorInfo = @ErrorInfo,
  804. VendorId = @VendorId,
  805. VendorErrorCode = @VendorErrorCode
  806. where Id = @Id
  807. """, parameters);
  808. bundleHandlerData.AddCompletedData(status);
  809. }
  810. }
  811. private async Task BundleAddServerMessage(BundleHandlerData<ServerMessage, string> bundleHandlerData)
  812. {
  813. //var sql = """
  814. // INSERT INTO [ServerMessage] ([ChargeBoxId], [CreatedBy], [CreatedOn], [InMessage], [OutAction], [OutRequest], [ReceivedOn], [SerialNo], [UpdatedOn])
  815. // OUTPUT INSERTED.Id
  816. // VALUES (@p0, @p1, @p2, @p3, @p4, @p5, @p6, @p7, @p8)
  817. // """;
  818. //using var conn = await sqlConnectionFactory.CreateAsync();
  819. //foreach(var data in bundleHandlerData.Datas)
  820. //{
  821. // var dymparam = new DynamicParameters();
  822. // dymparam.Add("@p0", data.ChargeBoxId);
  823. // dymparam.Add("@p1", data.CreatedBy);
  824. // dymparam.Add("@p2", data.CreatedOn);
  825. // dymparam.Add("@p3", data.InMessage);
  826. // dymparam.Add("@p4", data.OutAction);
  827. // dymparam.Add("@p5", data.OutRequest);
  828. // dymparam.Add("@p6", data.ReceivedOn);
  829. // dymparam.Add("@p7", data.SerialNo);
  830. // dymparam.Add("@p8", data.UpdatedOn);
  831. //}
  832. using var db = await contextFactory.CreateDbContextAsync();
  833. using var trans = await db.Database.BeginTransactionAsync();
  834. foreach (var message in bundleHandlerData.Datas)
  835. {
  836. await db.ServerMessage.AddAsync(message);
  837. }
  838. await db.SaveChangesAsync();
  839. await trans.CommitAsync();
  840. bundleHandlerData.CompletedDatas.AddRange(bundleHandlerData.Datas.Select(x => new KeyValuePair<ServerMessage, string>(x, x.SerialNo)));
  841. }
  842. private async Task AddServerMessageEF(ServerMessage message)
  843. {
  844. using var db = await contextFactory.CreateDbContextAsync();
  845. using var trans = await db.Database.BeginTransactionAsync();
  846. await db.ServerMessage.AddAsync(message);
  847. await db.SaveChangesAsync();
  848. await trans.CommitAsync();
  849. //db.ChangeTracker.Clear();
  850. }
  851. private async Task AddServerMessageDapper(ServerMessage message)
  852. {
  853. var parameters = new DynamicParameters();
  854. parameters.Add("@SerialNo", message.SerialNo, DbType.String, ParameterDirection.Input, 36);
  855. parameters.Add("@OutAction", message.OutAction, DbType.String, ParameterDirection.Input, 30);
  856. parameters.Add("@OutRequest", message.OutRequest, DbType.String, ParameterDirection.Input);
  857. parameters.Add("@InMessage", message.InMessage, DbType.String, ParameterDirection.Input);
  858. parameters.Add("@CreatedOn", message.CreatedOn, DbType.DateTime, ParameterDirection.Input);
  859. parameters.Add("@CreatedBy", message.CreatedBy, DbType.String, ParameterDirection.Input, 36);
  860. parameters.Add("@ReceivedOn", message.ReceivedOn, DbType.DateTime, ParameterDirection.Input);
  861. parameters.Add("@ChargeBoxId", message.ChargeBoxId, DbType.String, ParameterDirection.Input, 30);
  862. parameters.Add("@UpdatedOn", message.UpdatedOn, DbType.DateTime, ParameterDirection.Input);
  863. using var conn = await sqlConnectionFactory.CreateAsync();
  864. var resultCnt = await conn.ExecuteAsync("""
  865. INSERT INTO ServerMessage
  866. (SerialNo, OutAction, OutRequest, InMessage, CreatedOn, CreatedBy, ReceivedOn, ChargeBoxId, UpdatedOn)
  867. VALUES (@SerialNo, @OutAction, @OutRequest, @InMessage, @CreatedOn, @CreatedBy, @ReceivedOn, @ChargeBoxId, @UpdatedOn)
  868. """, parameters);
  869. if (resultCnt != 1)
  870. {
  871. throw new Exception("Insert failed");
  872. }
  873. return;
  874. }
  875. private async Task<int> AddNewTransactionRecordEF(TransactionRecord newTransaction)
  876. {
  877. using var db = await contextFactory.CreateDbContextAsync();
  878. await db.TransactionRecord.AddAsync(newTransaction);
  879. await db.SaveChangesAsync();
  880. return newTransaction.Id;
  881. }
  882. private async Task<int> AddNewTransactionRecordDapper(TransactionRecord newTransaction)
  883. {
  884. var parameters = new DynamicParameters();
  885. parameters.Add("@ChargeBoxId", newTransaction.ChargeBoxId, DbType.String, ParameterDirection.Input, 50);
  886. parameters.Add("@ConnectorId", newTransaction.ConnectorId, DbType.Int16, ParameterDirection.Input);
  887. parameters.Add("@CreatedOn", newTransaction.CreatedOn, DbType.DateTime, ParameterDirection.Input);
  888. parameters.Add("@UpdatedOn", newTransaction.UpdatedOn, DbType.DateTime, ParameterDirection.Input);
  889. parameters.Add("@StartTransactionReportedOn", newTransaction.StartTransactionReportedOn, DbType.DateTime, ParameterDirection.Input);
  890. parameters.Add("@StopTransactionReportedOn", newTransaction.StopTransactionReportedOn, DbType.DateTime, ParameterDirection.Input);
  891. parameters.Add("@StartIdTag", newTransaction.StartIdTag, DbType.String, ParameterDirection.Input, 20);
  892. parameters.Add("@MeterStart", newTransaction.MeterStart, DbType.Decimal, ParameterDirection.Input, precision: 18, scale: 2);
  893. parameters.Add("@MeterStop", newTransaction.MeterStop, DbType.Decimal, ParameterDirection.Input, precision: 18, scale: 2);
  894. parameters.Add("@CustomerId", newTransaction.CustomerId, DbType.Guid, ParameterDirection.Input);
  895. parameters.Add("@StartTime", newTransaction.StartTime, DbType.DateTime, ParameterDirection.Input);
  896. parameters.Add("@StopTime", newTransaction.StopTime, DbType.DateTime, ParameterDirection.Input);
  897. parameters.Add("@ReservationId", newTransaction.ReservationId, DbType.Int32, ParameterDirection.Input);
  898. parameters.Add("@RetryStartTransactionTimes", newTransaction.RetryStartTransactionTimes, DbType.Int32, ParameterDirection.Input);
  899. parameters.Add("@RetryStopTransactionTimes", newTransaction.RetryStopTransactionTimes, DbType.Int32, ParameterDirection.Input);
  900. parameters.Add("@Fee", newTransaction.Fee, DbType.String, ParameterDirection.Input, 1500);
  901. using var conn = await sqlConnectionFactory.CreateAsync();
  902. var id = await conn.QuerySingleAsync<int>("""
  903. INSERT INTO TransactionRecord
  904. (ChargeBoxId, ConnectorId, CreatedOn, UpdatedOn, StartTransactionReportedOn, StopTransactionReportedOn,
  905. StartIdTag, MeterStart, MeterStop, CustomerId, StartTime, StopTime, ReservationId, RetryStartTransactionTimes, RetryStopTransactionTimes, Fee)
  906. OUTPUT INSERTED.Id
  907. VALUES (@ChargeBoxId, @ConnectorId, @CreatedOn, @UpdatedOn, @StartTransactionReportedOn, @StopTransactionReportedOn,
  908. @StartIdTag, @MeterStart, @MeterStop, @CustomerId, @StartTime, @StopTime, @ReservationId, @RetryStartTransactionTimes, @RetryStopTransactionTimes, @Fee)
  909. """, parameters);
  910. return id;
  911. }
  912. private async Task<TransactionRecord> GetTransactionForStopTransactionEF(int transactionId, string chargeBoxId)
  913. {
  914. using var db = await contextFactory.CreateDbContextAsync();
  915. return await db.TransactionRecord.Where(x => x.Id == transactionId
  916. && x.ChargeBoxId == chargeBoxId).FirstOrDefaultAsync();
  917. }
  918. private async Task<TransactionRecord> GetTransactionForStopTransactionDapper(int transactionId, string chargeBoxId)
  919. {
  920. var parameters = new DynamicParameters();
  921. parameters.Add("@TransactionId", transactionId, DbType.Int32, ParameterDirection.Input);
  922. parameters.Add("@ChargeBoxId", chargeBoxId, DbType.String, ParameterDirection.Input, 50);
  923. using var conn = await sqlConnectionFactory.CreateAsync();
  924. var record = await conn.QuerySingleAsync<TransactionRecord>("""
  925. SELECT Id, ConnectorId, MeterStop, MeterStart, StartTime, StopTime FROM TransactionRecord
  926. WHERE Id = @TransactionId and ChargeBoxId = @ChargeBoxId
  927. """, parameters);
  928. return record;
  929. }
  930. private Task BulkInsertServerMessage(IEnumerable<ServerMessage> messages)
  931. {
  932. var table = new DataTable();
  933. table.Columns.Add("ChargeBoxId");
  934. table.Columns.Add("SerialNo");
  935. table.Columns.Add("OutAction");
  936. table.Columns.Add("OutRequest");
  937. table.Columns.Add("InMessage");
  938. table.Columns.Add("CreatedOn");
  939. table.Columns.Add("CreatedBy");
  940. table.Columns.Add("UpdatedOn");
  941. table.Columns.Add("ReceivedOn");
  942. foreach (var param in messages)
  943. {
  944. var row = table.NewRow();
  945. row["ChargeBoxId"] = param.ChargeBoxId;
  946. row["SerialNo"] = param.SerialNo;
  947. row["OutAction"] = param.OutAction;
  948. row["OutRequest"] = param.OutRequest;
  949. row["InMessage"] = param.InMessage;
  950. row["CreatedOn"] = param.CreatedOn;
  951. row["CreatedBy"] = param.CreatedBy;
  952. row["UpdatedOn"] = param.UpdatedOn;
  953. row["ReceivedOn"] = param.ReceivedOn;
  954. table.Rows.Add(row);
  955. }
  956. using SqlConnection sqlConnection = sqlConnectionFactory.Create();
  957. using SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(sqlConnection);
  958. sqlBulkCopy.BatchSize = messages.Count();
  959. sqlBulkCopy.DestinationTableName = "ServerMessage";
  960. sqlBulkCopy.ColumnMappings.Add("ChargeBoxId", "ChargeBoxId");
  961. sqlBulkCopy.ColumnMappings.Add("SerialNo", "SerialNo");
  962. sqlBulkCopy.ColumnMappings.Add("OutAction", "OutAction");
  963. sqlBulkCopy.ColumnMappings.Add("OutRequest", "OutRequest");
  964. sqlBulkCopy.ColumnMappings.Add("InMessage", "InMessage");
  965. sqlBulkCopy.ColumnMappings.Add("CreatedOn", "CreatedOn");
  966. sqlBulkCopy.ColumnMappings.Add("CreatedBy", "CreatedBy");
  967. sqlBulkCopy.ColumnMappings.Add("UpdatedOn", "UpdatedOn");
  968. sqlBulkCopy.ColumnMappings.Add("ReceivedOn", "ReceivedOn");
  969. return sqlBulkCopy.WriteToServerAsync(table);
  970. }
  971. private int GetStartupLimit(IConfiguration configuration)
  972. {
  973. var limitConfig = configuration["MainDbStartupLimit"];
  974. int limit = 5;
  975. if (limitConfig != default)
  976. {
  977. int.TryParse(limitConfig, out limit);
  978. }
  979. return limit;
  980. }
  981. private int GetOpLimit(IConfiguration configuration)
  982. {
  983. var limitConfig = configuration["MainDbOpLimit"];
  984. int limit = 500;
  985. if (limitConfig != default)
  986. {
  987. int.TryParse(limitConfig, out limit);
  988. }
  989. return limit;
  990. }
  991. private async Task<bool> UpdateHeartBeatsDapper(IEnumerable<Machine> heartBeatsData)
  992. {
  993. using var conn = await sqlConnectionFactory.CreateAsync();
  994. using var trans = await conn.BeginTransactionAsync();
  995. try
  996. {
  997. foreach (var data in heartBeatsData)
  998. {
  999. var parameters = new DynamicParameters();
  1000. parameters.Add("@Id", data.Id, DbType.String, ParameterDirection.Input, 36);
  1001. parameters.Add("@HeartbeatUpdatedOn", data.HeartbeatUpdatedOn, DbType.DateTime, ParameterDirection.Input);
  1002. parameters.Add("@ConnectionType", data.ConnectionType, DbType.Int32, ParameterDirection.Input);
  1003. var resultCnt = await conn.ExecuteAsync("""
  1004. UPDATE Machine
  1005. SET HeartbeatUpdatedOn = @HeartbeatUpdatedOn, ConnectionType = @ConnectionType
  1006. WHERE Id = @Id
  1007. """, parameters, trans);
  1008. if (resultCnt != 1)
  1009. {
  1010. throw new Exception("Update over one columes");
  1011. }
  1012. }
  1013. await trans.CommitAsync();
  1014. }
  1015. catch
  1016. {
  1017. logger.LogCritical("HeartBeatCheckTrigger update fail, roll back");
  1018. await trans.RollbackAsync();
  1019. return false;
  1020. }
  1021. return true;
  1022. }
  1023. private async Task<bool> UpdateHeartBeatsDapper(List<string> machineIds)
  1024. {
  1025. using var conn = await sqlConnectionFactory.CreateAsync();
  1026. try
  1027. {
  1028. var parameters = new DynamicParameters();
  1029. parameters.Add("@Ids", machineIds, size: 36);
  1030. parameters.Add("@HeartbeatUpdatedOn", DateTime.UtcNow, DbType.DateTime, ParameterDirection.Input);
  1031. var resultCnt = await conn.ExecuteAsync("""
  1032. UPDATE Machine
  1033. SET HeartbeatUpdatedOn = @HeartbeatUpdatedOn
  1034. WHERE Id in @Ids
  1035. """, parameters);
  1036. }
  1037. catch (Exception e)
  1038. {
  1039. logger.LogError(e.Message);
  1040. logger.LogCritical("HeartBeatCheckTrigger update fail");
  1041. return false;
  1042. }
  1043. return true;
  1044. }
  1045. private async Task<bool> UpdateHeartBeatsEF(IEnumerable<Machine> heartBeatsData)
  1046. {
  1047. using var db = await contextFactory.CreateDbContextAsync();
  1048. using var transaction = await db.Database.BeginTransactionAsync();
  1049. try
  1050. {
  1051. foreach (var data in heartBeatsData)
  1052. {
  1053. var machine = new Machine() { Id = data.Id };
  1054. if (machine != null)
  1055. {
  1056. db.Machine.Attach(machine);
  1057. machine.HeartbeatUpdatedOn = DateTime.UtcNow;
  1058. machine.ConnectionType = data.ConnectionType;
  1059. db.Entry(machine).Property(x => x.HeartbeatUpdatedOn).IsModified = true;
  1060. db.Entry(machine).Property(x => x.ConnectionType).IsModified = true;
  1061. }
  1062. }
  1063. await db.SaveChangesAsync();
  1064. await transaction.CommitAsync();
  1065. db.ChangeTracker.Clear();
  1066. }
  1067. catch (Exception ex)
  1068. {
  1069. logger.LogCritical(ex, "HeartBeatCheckTrigger update fail, roll back");
  1070. transaction.Rollback();
  1071. return false;
  1072. }
  1073. return true;
  1074. }
  1075. public async Task<string> GetMachineConnectorType(string chargeBoxId, CancellationToken token = default)
  1076. {
  1077. using var db = await contextFactory.CreateDbContextAsync(token);
  1078. var machine = await db.Machine.Where(x => x.ChargeBoxId == chargeBoxId).FirstOrDefaultAsync(token);
  1079. if (machine == null)
  1080. {
  1081. return null;
  1082. }
  1083. return machine.ConnectorType;
  1084. }
  1085. public async Task SetMachineConnectionType(string chargeBoxId, int v, CancellationToken token = default)
  1086. {
  1087. using var db = await contextFactory.CreateDbContextAsync(token);
  1088. var machine = await db.Machine.Where(x => x.ChargeBoxId == chargeBoxId).FirstOrDefaultAsync(token);
  1089. if (machine == null)
  1090. {
  1091. return;
  1092. }
  1093. machine.ConnectionType = v;
  1094. return;
  1095. }
  1096. }
  1097. public record MachineAndCustomerInfo(string MachineId, Guid CustomerId, string CustomerName);
  1098. public record StatusNotificationParam(string Id, ConnectorStatus Status);
  1099. public record UpdateMachineBasicInfoParam(string ChargeBoxId, Machine machine);