MainDbService.cs 50 KB

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