MainDbService.cs 50 KB

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