CoreProfileHandler.cs 82 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813
  1. using Dapper;
  2. using EVCB_OCPP.Domain;
  3. using EVCB_OCPP.Packet.Features;
  4. using EVCB_OCPP.Packet.Messages;
  5. using EVCB_OCPP.Packet.Messages.Core;
  6. using EVCB_OCPP.Packet.Messages.SubTypes;
  7. using EVCB_OCPP.WSServer.Dto;
  8. using EVCB_OCPP.WSServer.Helper;
  9. using EVCB_OCPP.WSServer.Service;
  10. using Microsoft.Data.SqlClient;
  11. using Microsoft.EntityFrameworkCore;
  12. using Microsoft.Extensions.Configuration;
  13. using Microsoft.Extensions.Logging;
  14. using Newtonsoft.Json;
  15. using Newtonsoft.Json.Linq;
  16. using System.Data;
  17. using System.Diagnostics;
  18. using System.Globalization;
  19. using EVCB_OCPP.WSServer.Service.WsService;
  20. using EVCB_OCPP.Domain.Models.MainDb;
  21. using EVCB_OCPP.Domain.ConnectionFactory;
  22. using EVCB_OCPP.WSServer.Service.DbService;
  23. using EVCB_OCPP.WSServer.Service.BusinessService;
  24. namespace EVCB_OCPP.WSServer.Message;
  25. public class ID_CreditDeductResult
  26. {
  27. public int txId { set; get; }
  28. public string creditNo { set; get; }
  29. public bool deductResult { set; get; }
  30. public bool isDonateInvoice { set; get; }
  31. public decimal amount { set; get; }
  32. public string approvalNo { set; get; }
  33. }
  34. public class ID_ReaderStatus
  35. {
  36. public int ConnectorId { set; get; }
  37. public string creditNo { set; get; }
  38. public string SerialNo { set; get; }
  39. public int readerStatus { set; get; }
  40. public string VEMData { set; get; }
  41. public DateTime Timestamp { set; get; }
  42. }
  43. internal partial class ProfileHandler
  44. {
  45. private readonly ILogger logger;
  46. private readonly ServerMessageService messageService;
  47. private readonly IDbContextFactory<MainDBContext> maindbContextFactory;
  48. private readonly ISqlConnectionFactory<WebDBConetext> webDbConnectionFactory;
  49. private readonly MeterValueDbService meterValueDbService;
  50. private readonly ConnectorStatusDbService connectorStatusDbService;
  51. //private readonly IDbContextFactory<MeterValueDBContext> metervaluedbContextFactory;
  52. private readonly IBusinessServiceFactory businessServiceFactory;
  53. private readonly IMainDbService mainDbService;
  54. private readonly WebDbService webDbService;
  55. private OuterHttpClient httpClient;
  56. public ProfileHandler(
  57. IConfiguration configuration,
  58. IDbContextFactory<MainDBContext> maindbContextFactory,
  59. ISqlConnectionFactory<WebDBConetext> webDbConnectionFactory,
  60. MeterValueDbService meterValueDbService,
  61. ConnectorStatusDbService connectorStatusDbService,
  62. IBusinessServiceFactory businessServiceFactory,
  63. IMainDbService mainDbService,
  64. WebDbService webDbService,
  65. ILogger<ProfileHandler> logger,
  66. ServerMessageService messageService,
  67. OuterHttpClient httpClient)
  68. {
  69. this.logger = logger;
  70. this.messageService = messageService;
  71. this.maindbContextFactory = maindbContextFactory;
  72. this.webDbConnectionFactory = webDbConnectionFactory;
  73. this.meterValueDbService = meterValueDbService;
  74. this.connectorStatusDbService = connectorStatusDbService;
  75. this.mainDbService = mainDbService;
  76. this.webDbService = webDbService;
  77. this.businessServiceFactory = businessServiceFactory;
  78. this.httpClient = httpClient;
  79. }
  80. async internal Task<MessageResult> ExecuteCoreRequest(Actions action, WsClientData session, IRequest request)
  81. {
  82. Stopwatch watch = new Stopwatch();
  83. //if (action == Actions.Heartbeat || action == Actions.StopTransaction)
  84. //{
  85. // watch.Start();
  86. //}
  87. watch.Start();
  88. MessageResult result = new MessageResult() { Success = false };
  89. try
  90. {
  91. switch (action)
  92. {
  93. case Actions.DataTransfer:
  94. {
  95. DataTransferRequest _request = request as DataTransferRequest;
  96. var confirm = new DataTransferConfirmation() { status = DataTransferStatus.UnknownMessageId };
  97. if (_request.messageId == "ID_CreditDeductResult")
  98. {
  99. var creditDeductResult = JsonConvert.DeserializeObject<ID_CreditDeductResult>(_request.data);
  100. if (session.CustomerId == new Guid("009E603C-79CD-4620-A2B8-D9349C0E8AD8"))
  101. {
  102. var report = new
  103. {
  104. ChargeBoxId = session.ChargeBoxId,
  105. IsDonateInvoice = creditDeductResult.isDonateInvoice,
  106. CreditNo = creditDeductResult.creditNo,
  107. DeductResult = creditDeductResult.deductResult,
  108. SessionId = creditDeductResult.txId,
  109. ApprovalNo = creditDeductResult.approvalNo,
  110. TotalCost = creditDeductResult.amount,
  111. };
  112. var response = await httpClient.Post(GlobalConfig.TCC_API_URL + "prepare_issue_invoice", new Dictionary<string, string>()
  113. {
  114. { "PartnerId",session.CustomerId.ToString()}
  115. }, report, GlobalConfig.TCC_SALTKEY);
  116. logger.LogDebug(JsonConvert.SerializeObject(response));
  117. }
  118. confirm.status = DataTransferStatus.Accepted;
  119. confirm.data = JsonConvert.SerializeObject(new { txId = creditDeductResult.txId, creditNo = creditDeductResult.creditNo, msgId = _request.messageId });
  120. }
  121. if (_request.messageId == "ID_ReaderStatus")
  122. {
  123. if (session.CustomerId == new Guid("009E603C-79CD-4620-A2B8-D9349C0E8AD8"))
  124. {
  125. var preauth_status = JsonConvert.DeserializeObject<ID_ReaderStatus>(_request.data);
  126. var report = new
  127. {
  128. ChargeBoxId = session.ChargeBoxId,
  129. ConnectorId = preauth_status.ConnectorId,
  130. CreditNo = preauth_status.creditNo,
  131. ReaderStatus = preauth_status.readerStatus,
  132. SerialNo = preauth_status.SerialNo,
  133. VEMData = preauth_status.VEMData,
  134. Timestamp = preauth_status.Timestamp
  135. };
  136. var response = await httpClient.Post(GlobalConfig.TCC_API_URL + "preauth_status", new Dictionary<string, string>()
  137. {
  138. { "PartnerId",session.CustomerId.ToString()}
  139. }, report, GlobalConfig.TCC_SALTKEY);
  140. confirm.status = DataTransferStatus.Accepted;
  141. }
  142. }
  143. if (_request.messageId == "ID_OCMF")
  144. {
  145. JObject jo = JObject.Parse(_request.data);
  146. logger.LogDebug("{0}\r\n{1}\r\n{2}", jo["txId"].Value<int>(), jo["dataString"].Value<string>(), jo["publicKey"].Value<string>());
  147. await mainDbService.AddOCMF(new Ocmf()
  148. {
  149. TransactionId = jo["txId"].Value<int>(),
  150. DataString = jo["dataString"].Value<string>(),
  151. PublicKey = jo["publicKey"].Value<string>()
  152. });
  153. confirm.status = DataTransferStatus.Accepted;
  154. confirm.data = JsonConvert.SerializeObject(new { txId = jo["txId"].Value<int>(), msgId = _request.messageId });
  155. }
  156. if (_request.messageId == "Authorize")
  157. {
  158. string iso15118_token = string.Empty;
  159. JObject jo = JObject.Parse(_request.data);
  160. if (jo.ContainsKey("idToken"))
  161. {
  162. iso15118_token = jo["idToken"]["idToken"].Value<string>();
  163. }
  164. confirm.status = DataTransferStatus.Accepted;
  165. confirm.data = JsonConvert.SerializeObject(
  166. new
  167. {
  168. certificateStatus = iso15118_token == "12345678901234" ? "Accepted" : "CertificateExpired",
  169. idTokenInfo = new
  170. {
  171. status = iso15118_token == "12345678901234" ? "Accepted" : "Invalid"
  172. }
  173. });
  174. }
  175. result.Message = confirm;
  176. result.Success = true;
  177. }
  178. break;
  179. case Actions.BootNotification:
  180. {
  181. BootNotificationRequest _request = request as BootNotificationRequest;
  182. int heartbeat_interval = GlobalConfig.GetHEARTBEAT_INTERVAL();
  183. //var _machine = db.Machine.FirstOrDefault(x => x.ChargeBoxId == session.ChargeBoxId);
  184. if (session.BootStatus == BootStatus.Startup)
  185. {
  186. Machine _machine = new();
  187. _machine.ChargeBoxSerialNumber = string.IsNullOrEmpty(_request.chargeBoxSerialNumber) ? string.Empty : _request.chargeBoxSerialNumber;
  188. _machine.ChargePointSerialNumber = string.IsNullOrEmpty(_request.chargePointSerialNumber) ? string.Empty : _request.chargePointSerialNumber;
  189. _machine.ChargePointModel = string.IsNullOrEmpty(_request.chargePointModel) ? string.Empty : _request.chargePointModel;
  190. _machine.ChargePointVendor = string.IsNullOrEmpty(_request.chargePointVendor) ? string.Empty : _request.chargePointVendor;
  191. _machine.FwCurrentVersion = string.IsNullOrEmpty(_request.firmwareVersion) ? string.Empty : _request.firmwareVersion;
  192. _machine.Iccid = string.IsNullOrEmpty(_request.iccid) ? string.Empty : _request.iccid;
  193. //_machine.Iccid = DateTime.UtcNow.ToString("yy-MM-dd HH:mm");
  194. _machine.Imsi = string.IsNullOrEmpty(_request.imsi) ? string.Empty : _request.imsi;
  195. _machine.MeterSerialNumber = string.IsNullOrEmpty(_request.meterSerialNumber) ? string.Empty : _request.meterSerialNumber;
  196. _machine.MeterType = string.IsNullOrEmpty(_request.meterType) ? string.Empty : _request.meterType;
  197. await mainDbService.UpdateMachineBasicInfo(session.ChargeBoxId, _machine);
  198. }
  199. int toReturnInterval = 5;
  200. RegistrationStatus toReturnRegistrationStatus = RegistrationStatus.Rejected ;
  201. switch (session.BootStatus)
  202. {
  203. case BootStatus.Startup:
  204. case BootStatus.Initializing:
  205. toReturnInterval = 5;
  206. toReturnRegistrationStatus = RegistrationStatus.Pending;
  207. break;
  208. case BootStatus.Pending:
  209. case BootStatus.Accepted:
  210. var configValue = await mainDbService.GetMachineHeartbeatInterval(session.ChargeBoxId);
  211. if (configValue != null)
  212. {
  213. int.TryParse(configValue, out heartbeat_interval);
  214. heartbeat_interval = heartbeat_interval == 0 ? GlobalConfig.GetHEARTBEAT_INTERVAL() : heartbeat_interval;
  215. }
  216. toReturnInterval = heartbeat_interval;
  217. toReturnRegistrationStatus = RegistrationStatus.Accepted;
  218. session.BootStatus = BootStatus.Accepted;
  219. break;
  220. }
  221. var confirm = new BootNotificationConfirmation()
  222. {
  223. currentTime = DateTime.UtcNow,
  224. interval = toReturnInterval,
  225. status = toReturnRegistrationStatus
  226. };
  227. result.Message = confirm;
  228. result.Success = true;
  229. }
  230. break;
  231. case Actions.StatusNotification:
  232. {
  233. var statusNotificationTimer = Stopwatch.StartNew();
  234. long s1 = 0, s2 = 0, s3 = 0, s4 = 0, s5 = 0;
  235. //只保留最新上報狀況
  236. StatusNotificationRequest _request = request as StatusNotificationRequest;
  237. int preStatus = 0;
  238. ConnectorStatus _oldStatus;
  239. await connectorStatusDbService.InsertAsync(session.ChargeBoxId,(byte) _request.connectorId, (int)_request.status, _request.timestamp.HasValue? _request.timestamp.Value.ToUniversalTime(): DateTime.UtcNow,
  240. _request.info, _request.vendorId, _request.vendorErrorCode, (int)_request.errorCode);
  241. _oldStatus = await mainDbService.GetConnectorStatus(session.ChargeBoxId, _request.connectorId);
  242. s1 = statusNotificationTimer.ElapsedMilliseconds;
  243. if (_oldStatus != null && (_request.status != (ChargePointStatus)_oldStatus.Status || _request.status == ChargePointStatus.Faulted))
  244. {
  245. preStatus = _oldStatus.Status;
  246. await mainDbService.UpdateConnectorStatus(_oldStatus.Id, new ConnectorStatus()
  247. {
  248. CreatedOn = _request.timestamp.HasValue ? _request.timestamp.Value.ToUniversalTime() : DateTime.UtcNow,
  249. Status = (int)_request.status,
  250. ChargePointErrorCodeId = (int)_request.errorCode,
  251. ErrorInfo = string.IsNullOrEmpty(_request.info) ? string.Empty : _request.info,
  252. VendorId = string.IsNullOrEmpty(_request.vendorId) ? string.Empty : _request.vendorId,
  253. VendorErrorCode = string.IsNullOrEmpty(_request.vendorErrorCode) ? string.Empty : _request.vendorErrorCode
  254. });
  255. if (preStatus == (int)ChargePointStatus.Faulted)
  256. {
  257. if (_request.status != ChargePointStatus.Faulted ||
  258. (_oldStatus.ChargePointErrorCodeId != (int)_request.errorCode || _oldStatus.VendorErrorCode != _request.vendorErrorCode))
  259. {
  260. await mainDbService.FillupFinishedTimetoMachineError(
  261. ChargeBoxId: session.ChargeBoxId,
  262. ConnectorId: (byte)_request.connectorId,
  263. FinishedOn: _request.timestamp.HasValue ? _request.timestamp.Value.ToUniversalTime() : DateTime.UtcNow
  264. );
  265. }
  266. }
  267. }
  268. s2 = statusNotificationTimer.ElapsedMilliseconds;
  269. if (_oldStatus == null)
  270. {
  271. await mainDbService.AddConnectorStatus(
  272. ChargeBoxId: session.ChargeBoxId,
  273. ConnectorId: (byte)_request.connectorId,
  274. CreatedOn: _request.timestamp.HasValue ? _request.timestamp.Value.ToUniversalTime() : DateTime.UtcNow,
  275. Status: (int)_request.status,
  276. ChargePointErrorCodeId: (int)_request.errorCode,
  277. ErrorInfo: string.IsNullOrEmpty(_request.info) ? string.Empty : _request.info,
  278. VendorId: string.IsNullOrEmpty(_request.vendorId) ? string.Empty : _request.vendorId,
  279. VendorErrorCode: string.IsNullOrEmpty(_request.vendorErrorCode) ? string.Empty : _request.vendorErrorCode);
  280. }
  281. s3 = statusNotificationTimer.ElapsedMilliseconds;
  282. bool isNeedAddMachineError = CheckNeedAddMachineError(_request, _oldStatus);
  283. //if (_request.status == Packet.Messages.SubTypes.ChargePointStatus.Faulted &&
  284. //(_oldStatus != null &&
  285. //(_oldStatus.ChargePointErrorCodeId != (int)_request.errorCode && _oldStatus.VendorErrorCode != _request.vendorErrorCode)))
  286. if (isNeedAddMachineError)
  287. {
  288. await mainDbService.AddMachineError(ConnectorId: (byte)_request.connectorId,
  289. CreatedOn: _request.timestamp.HasValue ? _request.timestamp.Value.ToUniversalTime() : DateTime.UtcNow,
  290. Status: (int)_request.status,
  291. ChargeBoxId: session.ChargeBoxId,
  292. ErrorCodeId: (int)_request.errorCode,
  293. ErrorInfo: string.IsNullOrEmpty(_request.info) ? string.Empty : _request.info,
  294. PreStatus: _oldStatus == null ? -1 : preStatus,
  295. VendorErrorCode: string.IsNullOrEmpty(_request.vendorErrorCode) ? string.Empty : _request.vendorErrorCode,
  296. VendorId: string.IsNullOrEmpty(_request.vendorId) ? string.Empty : _request.vendorId);
  297. }
  298. s4 = statusNotificationTimer.ElapsedMilliseconds;
  299. if (_request.status == Packet.Messages.SubTypes.ChargePointStatus.Faulted)
  300. {
  301. //var businessService = BusinessServiceFactory.CreateBusinessService(session.CustomerId.ToString());
  302. //var businessService = await serviceProvider.GetService<BusinessServiceFactory>().CreateBusinessService(session.CustomerId.ToString());
  303. var businessService = await businessServiceFactory.CreateBusinessService(session.CustomerId);
  304. var notification = businessService.NotifyFaultStatus(new ErrorDetails()
  305. {
  306. ChargeBoxId = session.ChargeBoxId,
  307. ConnectorId = _request.connectorId,
  308. ErrorCode = _request.errorCode,
  309. Info = string.IsNullOrEmpty(_request.info) ? string.Empty : _request.info,
  310. OCcuredOn = _request.timestamp.HasValue ? _request.timestamp.Value.ToUniversalTime() : DateTime.UtcNow,
  311. VendorErrorCode = string.IsNullOrEmpty(_request.vendorErrorCode) ? string.Empty : _request.vendorErrorCode,
  312. });
  313. }
  314. s5 = statusNotificationTimer.ElapsedMilliseconds;
  315. var confirm = new StatusNotificationConfirmation() { };
  316. result.Message = confirm;
  317. result.Success = true;
  318. statusNotificationTimer.Stop();
  319. if (statusNotificationTimer.ElapsedMilliseconds / 1000 > 1)
  320. {
  321. logger.LogCritical(string.Format("StatusNotification took {0}/{1}/{2}/{3}/{4}", s1, s2, s3, s4, s5));
  322. }
  323. }
  324. break;
  325. case Actions.Heartbeat:
  326. {
  327. var confirm = new HeartbeatConfirmation() { currentTime = DateTime.UtcNow };
  328. result.Message = confirm;
  329. result.Success = true;
  330. }
  331. break;
  332. case Actions.MeterValues:
  333. {
  334. var meterValueTimer = Stopwatch.StartNew();
  335. long s1 = 0, s2 = 0, s3 = 0, s4 = 0, s5 = 0, insertTasksCnt = 0;
  336. MeterValuesRequest _request = request as MeterValuesRequest;
  337. if (_request.meterValue.Count > 0)
  338. {
  339. s1 = meterValueTimer.ElapsedMilliseconds;
  340. foreach (var item in _request.meterValue)
  341. {
  342. if (_request.transactionId.HasValue)
  343. {
  344. decimal meterStart = 0;
  345. var energy_Register = item.sampledValue.Where(x => x.measurand == Measurand.Energy_Active_Import_Register).FirstOrDefault();
  346. if (energy_Register != null)
  347. {
  348. decimal energyRegister = decimal.Parse(energy_Register.value);
  349. energyRegister = energy_Register.unit.Value == UnitOfMeasure.kWh ? decimal.Multiply(energyRegister, 1000) : energyRegister;
  350. using (var maindb = await maindbContextFactory.CreateDbContextAsync())
  351. {
  352. meterStart = await maindb.TransactionRecord
  353. .Where(x => x.Id == _request.transactionId.Value).Select(x => x.MeterStart)
  354. .FirstOrDefaultAsync();
  355. }
  356. item.sampledValue.Add(new SampledValue()
  357. {
  358. context = ReadingContext.Sample_Periodic,
  359. format = ValueFormat.Raw,
  360. location = Location.Outlet,
  361. phase = item.sampledValue.Where(x => x.measurand == Measurand.Energy_Active_Import_Register).Select(x => x.phase).FirstOrDefault(),
  362. unit = UnitOfMeasure.Wh,
  363. measurand = Measurand.TotalEnergy,
  364. value = decimal.Subtract(energyRegister, meterStart).ToString()
  365. });
  366. }
  367. }
  368. }
  369. s2 = meterValueTimer.ElapsedMilliseconds;
  370. //List<Task> insertTasks = new();
  371. List<InsertMeterValueParam> datas = new();
  372. foreach (var item in _request.meterValue)
  373. {
  374. foreach (var sampleVaule in item.sampledValue)
  375. {
  376. if (sampleVaule.format == ValueFormat.SignedData) continue;
  377. decimal value = Convert.ToDecimal(sampleVaule.value);
  378. datas.Add(new InsertMeterValueParam(
  379. chargeBoxId: session.ChargeBoxId
  380. , connectorId: (byte)_request.connectorId
  381. , value: value
  382. , createdOn: item.timestamp
  383. , contextId: sampleVaule.context.HasValue ? (int)sampleVaule.context : 0
  384. , formatId: sampleVaule.format.HasValue ? (int)sampleVaule.format : 0
  385. , measurandId: sampleVaule.measurand.HasValue ? (int)sampleVaule.measurand : 0
  386. , phaseId: sampleVaule.phase.HasValue ? (int)sampleVaule.phase : 0
  387. , locationId: sampleVaule.location.HasValue ? (int)sampleVaule.location : 0
  388. , unitId: sampleVaule.unit.HasValue ? (int)sampleVaule.unit : 0
  389. , transactionId: _request.transactionId.HasValue ? _request.transactionId.Value : -1));
  390. //var task = meterValueDbService.InsertAsync(
  391. // chargeBoxId: session.ChargeBoxId
  392. // , connectorId: (byte)_request.connectorId
  393. // , value: value
  394. // , createdOn: item.timestamp
  395. // , contextId: sampleVaule.context.HasValue ? (int)sampleVaule.context : 0
  396. // , formatId: sampleVaule.format.HasValue ? (int)sampleVaule.format : 0
  397. // , measurandId: sampleVaule.measurand.HasValue ? (int)sampleVaule.measurand : 0
  398. // , phaseId: sampleVaule.phase.HasValue ? (int)sampleVaule.phase : 0
  399. // , locationId: sampleVaule.location.HasValue ? (int)sampleVaule.location : 0
  400. // , unitId: sampleVaule.unit.HasValue ? (int)sampleVaule.unit : 0
  401. // , transactionId: _request.transactionId.HasValue ? _request.transactionId.Value : -1);
  402. //var task = Task.Delay(2_000);
  403. //insertTasks.Add(task);
  404. }
  405. }
  406. //insertTasksCnt = insertTasks.Count;
  407. insertTasksCnt = datas.Count;
  408. s3 = meterValueTimer.ElapsedMilliseconds;
  409. //await Task.WhenAll(insertTasks);
  410. await meterValueDbService.InsertBundleAsync(datas);
  411. s4 = meterValueTimer.ElapsedMilliseconds;
  412. }
  413. // if (energy_kwh > 0)
  414. if (_request.transactionId != null)
  415. {
  416. try
  417. {
  418. if (session.IsBilling)
  419. {
  420. await messageService.SendDataTransferRequest(
  421. session.ChargeBoxId,
  422. messageId: "ID_TxEnergy",
  423. vendorId: "Phihong Technology",
  424. data: JsonConvert.SerializeObject(new { txId = _request.transactionId, ConnectorId = _request.connectorId })
  425. );
  426. }
  427. }
  428. catch (Exception ex)
  429. {
  430. logger.LogTrace(string.Format("{0} :{1}", session.ChargeBoxId + " RunningCost", ex.Message));
  431. }
  432. }
  433. s5 = meterValueTimer.ElapsedMilliseconds;
  434. meterValueTimer.Stop();
  435. if (meterValueTimer.ElapsedMilliseconds / 1000 > 1)
  436. {
  437. logger.LogCritical(string.Format("MeterValues took {0}/{1}/{2}/{3}/{4}:{5}", s1 / 1000, s2 / 1000, s3 / 1000, s4 / 1000, s5 / 1000, insertTasksCnt));
  438. }
  439. var confirm = new MeterValuesConfirmation() { };
  440. result.Message = confirm;
  441. result.Success = true;
  442. }
  443. break;
  444. case Actions.StartTransaction:
  445. {
  446. var timer = Stopwatch.StartNew();
  447. long t0 = 0, t1 = 0, t2 = 0, t3 = 0, t4 = 0, t5 = 0;
  448. StartTransactionRequest _request = request as StartTransactionRequest;
  449. int _transactionId = -1;
  450. var businessService = await businessServiceFactory.CreateBusinessService(session.CustomerId);
  451. t0 = timer.ElapsedMilliseconds;
  452. var _idTagInfo = new IdTagInfo() { expiryDate = DateTime.UtcNow.AddDays(1), status = AuthorizationStatus.Accepted };
  453. #region PnC 邏輯
  454. if (!string.IsNullOrEmpty(_request.idTag))
  455. {
  456. _request.idTag = _request.idTag.StartsWith("vid:") ? _request.idTag.Replace("vid:", "") : _request.idTag;
  457. }
  458. #endregion
  459. if (_request.idTag != "Backend")
  460. {
  461. var authorization_result = await businessService.Authorize(session.ChargeBoxId, _request.idTag, source: Actions.StartTransaction.ToString());
  462. _idTagInfo = authorization_result.IdTagInfo;
  463. t1 = timer.ElapsedMilliseconds;
  464. if (_idTagInfo.status == AuthorizationStatus.Accepted && authorization_result.ChargePointFee != null)
  465. {
  466. var price = authorization_result.ChargePointFee.Where(x => x.IsAC == session.IsAC).First();
  467. if (price != null)
  468. {
  469. session.UserPrices[_request.idTag] = price.PerkWhFee.HasValue ? JsonConvert.SerializeObject(new List<ChargingPrice>() { new ChargingPrice() { StartTime = "00:00", EndTime = "23:59", Fee = price.PerkWhFee.Value } }) : price.PerHourFee.Value.ToString();
  470. session.UserPrices[_request.idTag] += "|+" + authorization_result.AccountBalance + "+" + "&" + price.ParkingFee + "&|" + price.Currency;
  471. }
  472. }
  473. }
  474. //特例****飛宏客戶旗下的電樁,若遇到Portal沒回應的狀況 ~允許充電
  475. if (session.CustomerId.ToString().ToUpper() == "8456AED9-6DD9-4BF3-A94C-9F5DCB9506F7" && _idTagInfo.status == AuthorizationStatus.ConcurrentTx)
  476. {
  477. _idTagInfo = new IdTagInfo() { expiryDate = DateTime.UtcNow.AddDays(1), status = AuthorizationStatus.Accepted };
  478. }
  479. string accountBalance = "0";
  480. if (session.CustomerId.ToString().ToUpper() == "10C7F5BD-C89A-4E2A-8611-B617E0B41A73")
  481. {
  482. using (SqlConnection conn = await webDbConnectionFactory.CreateAsync())
  483. {
  484. var parameters = new DynamicParameters();
  485. parameters.Add("@IdTag", _request.idTag, DbType.String, ParameterDirection.Input, 50);
  486. string strSql = "select parentIdTag from [dbo].[LocalListDetail] where ListId = 27 and IdTag=@IdTag; ";
  487. accountBalance = await conn.ExecuteScalarAsync<string>(strSql, parameters);
  488. }
  489. }
  490. var _CustomerId = await mainDbService.GetCustomerIdByChargeBoxId(session.ChargeBoxId);
  491. t2 = timer.ElapsedMilliseconds;
  492. var _existedTx = await mainDbService.TryGetDuplicatedTransactionId(session.ChargeBoxId, _CustomerId, _request.connectorId, _request.timestamp);
  493. t3 = timer.ElapsedMilliseconds;
  494. if (_existedTx != null)
  495. {
  496. _transactionId = _existedTx.Value;
  497. logger.LogError("Duplication ***************************************************** " + _existedTx);
  498. }
  499. else
  500. {
  501. TransactionRecord _newTransaction;//= new TransactionRecord();
  502. _newTransaction = new TransactionRecord()
  503. {
  504. ChargeBoxId = session.ChargeBoxId,
  505. ConnectorId = (byte)_request.connectorId,
  506. CreatedOn = DateTime.UtcNow,
  507. StartIdTag = _request.idTag,
  508. MeterStart = _request.meterStart,
  509. CustomerId = _CustomerId,
  510. StartTime = _request.timestamp.ToUniversalTime(),
  511. ReservationId = _request.reservationId.HasValue ? _request.reservationId.Value : 0,
  512. };
  513. if (session.UserPrices.ContainsKey(_request.idTag))
  514. {
  515. _newTransaction.Fee = !session.IsBilling ? string.Empty : session.UserPrices[_request.idTag];
  516. }
  517. else
  518. {
  519. _newTransaction.Fee = !session.IsBilling ? string.Empty : session.BillingMethod == 1 ? JsonConvert.SerializeObject(session.ChargingPrices) : session.ChargingFeebyHour.ToString();
  520. _newTransaction.Fee += !session.IsBilling ? string.Empty : "|+" + accountBalance + "+" + "&" + session.ParkingFee + "&|" + session.Currency;
  521. }
  522. //using (var db = await maindbContextFactory.CreateDbContextAsync())
  523. //{
  524. // await db.TransactionRecord.AddAsync(_newTransaction);
  525. // await db.SaveChangesAsync();
  526. // _transactionId = _newTransaction.Id;
  527. //}
  528. _transactionId = await mainDbService.AddNewTransactionRecord(_newTransaction);
  529. t4 = timer.ElapsedMilliseconds;
  530. logger.LogInformation("***************************************************** ");
  531. logger.LogInformation(string.Format("{0} :TransactionId {1} ", session.ChargeBoxId, _transactionId));
  532. logger.LogInformation("***************************************************** ");
  533. }
  534. var confirm = new StartTransactionConfirmation()
  535. {
  536. idTagInfo = _idTagInfo,
  537. transactionId = _transactionId
  538. };
  539. result.Message = confirm;
  540. result.Success = true;
  541. timer.Stop();
  542. t5 = timer.ElapsedMilliseconds;
  543. if (t5 > 1000)
  544. {
  545. logger.Log(LogLevel.Critical, "{action} {ChargeBoxId} time {t0}/{t1}/{t2}/{t3}/{t4}/{totalTime}", action.ToString(), session.ChargeBoxId, t0, t1, t2, t3, t4, t5);
  546. }
  547. }
  548. break;
  549. case Actions.StopTransaction:
  550. {
  551. StopTransactionRequest _request = request as StopTransactionRequest;
  552. //遠傳太久以前的停止充電 或 電樁上傳TransactionId=0 直接拒絕 避免電樁持續重送~~~~~~~
  553. if (_request.timestamp < new DateTime(2021, 11, 1) || _request.transactionId == 0)
  554. {
  555. var confirm = new StopTransactionConfirmation()
  556. {
  557. idTagInfo = new IdTagInfo()
  558. {
  559. status = AuthorizationStatus.Invalid
  560. }
  561. };
  562. result.Message = confirm;
  563. result.Success = true;
  564. return result;
  565. }
  566. long getDateTimeTime, getServiceTime, getTagInfoTime, dbOpTime = 0, meterValueTime = 0;
  567. var stopTrasactionTimer = Stopwatch.StartNew();
  568. int _ConnectorId = 0;
  569. var utcNow = DateTime.UtcNow;
  570. getDateTimeTime = stopTrasactionTimer.ElapsedMilliseconds;
  571. var businessService = await businessServiceFactory.CreateBusinessService(session.CustomerId);
  572. getServiceTime = stopTrasactionTimer.ElapsedMilliseconds;
  573. TransactionRecord transaction;
  574. transaction = await mainDbService.GetTransactionForStopTransaction(_request.transactionId, session.ChargeBoxId);
  575. var _idTagInfo = string.IsNullOrEmpty(_request.idTag) ? null : (
  576. _request.idTag == "Backend" ?
  577. new IdTagInfo()
  578. {
  579. expiryDate = utcNow.AddDays(1),
  580. status = AuthorizationStatus.Accepted
  581. } :
  582. (await businessService.Authorize(session.ChargeBoxId, _request.idTag, transaction?.ConnectorId, source: Actions.StopTransaction.ToString())).IdTagInfo
  583. );
  584. getTagInfoTime = stopTrasactionTimer.ElapsedMilliseconds;
  585. //特例****飛宏客戶旗下的電樁,若遇到Portal沒回應的狀況 ~允許充電
  586. if (session.CustomerId.ToString().ToUpper() == "8456AED9-6DD9-4BF3-A94C-9F5DCB9506F7" && _idTagInfo != null && _idTagInfo.status == AuthorizationStatus.ConcurrentTx)
  587. {
  588. _idTagInfo = new IdTagInfo() { expiryDate = utcNow.AddDays(1), status = AuthorizationStatus.Accepted };
  589. }
  590. #region PnC 邏輯
  591. if (!string.IsNullOrEmpty(_request.idTag))
  592. {
  593. _request.idTag = _request.idTag.StartsWith("vid:") ? _request.idTag.Replace("vid:", "") : _request.idTag;
  594. }
  595. #endregion
  596. try
  597. {
  598. if (transaction is null)
  599. {
  600. result.Exception = new Exception("Can't find transactionId " + _request.transactionId);
  601. }
  602. else
  603. {
  604. #region 加入Transaction Start/StopSOC
  605. if (!session.IsAC && _request.transactionId > 0)
  606. {
  607. var SearchTime = transaction.StartTime;
  608. var txStopTime = _request.timestamp;
  609. List<int> SOCCollection = new List<int>();
  610. while (SearchTime.Date <= txStopTime.Date)
  611. {
  612. var searchResults = await meterValueDbService.GetTransactionSOC(transaction.Id, SearchTime.Date);
  613. SOCCollection.AddRange(searchResults);
  614. SearchTime = SearchTime.AddDays(1);
  615. }
  616. SOCCollection.Sort();
  617. logger.LogDebug(string.Format("SOCCollection:" + String.Join(",", SOCCollection.Select(x => x.ToString()).ToArray())));
  618. await mainDbService.UpdateTransactionSOC(
  619. transaction.Id,
  620. startsoc: SOCCollection.Count == 0 ? "" : SOCCollection.First().ToString("0"),
  621. stopsoc: SOCCollection.Count == 0 ? "" : SOCCollection.Last().ToString("0")
  622. );
  623. }
  624. #endregion
  625. _ConnectorId = transaction.ConnectorId;
  626. var confirm = new StopTransactionConfirmation()
  627. {
  628. idTagInfo = _idTagInfo
  629. };
  630. //Avoid rewrite transaction data
  631. if (transaction.StopTime != GlobalConfig.DefaultNullTime)
  632. {
  633. result.Message = confirm;
  634. result.Success = true;
  635. return result;
  636. }
  637. await mainDbService.UpdateTransaction(_request.transactionId,
  638. meterStop: _request.meterStop,
  639. stopTime: _request.timestamp.ToUniversalTime(),
  640. stopReasonId: _request.reason.HasValue ? (int)_request.reason.Value : 0,
  641. stopReason: _request.reason.HasValue ? _request.reason.Value.ToString() : Reason.Local.ToString(),
  642. stopIdTag: _request.idTag,
  643. receipt: string.Empty,
  644. cost: session.IsBilling ? -1 : 0);
  645. if (_request.transactionData == null || _request.transactionData.Count == 0)
  646. {
  647. _request.transactionData = new List<MeterValue>()
  648. {
  649. new MeterValue() { timestamp= _request.timestamp, sampledValue=new List<SampledValue>()}
  650. };
  651. }
  652. if (_request.transactionData != null && _request.transactionData.Count > 0)
  653. {
  654. //清除 StopTransaction TransactionData
  655. _request.transactionData[0].sampledValue.Clear();
  656. _request.transactionData[0].sampledValue.Add(new SampledValue()
  657. {
  658. context = ReadingContext.Transaction_End,
  659. format = ValueFormat.Raw,
  660. location = Location.Outlet,
  661. phase = _request.transactionData[0].sampledValue.Where(x => x.context.HasValue).Select(x => x.phase).FirstOrDefault(),
  662. unit = UnitOfMeasure.Wh,
  663. measurand = Measurand.TotalEnergy,
  664. value = decimal.Subtract(transaction.MeterStop, transaction.MeterStart).ToString()
  665. });
  666. }
  667. if (session.IsBilling || await webDbService.GetStationIsPeriodEnergyRequired(session.ChargeBoxId))
  668. {
  669. await messageService.SendDataTransferRequest(
  670. session.ChargeBoxId,
  671. messageId: "ID_TxEnergy",
  672. vendorId: "Phihong Technology",
  673. data: JsonConvert.SerializeObject(new { txId = _request.transactionId, ConnectorId = transaction.ConnectorId })
  674. );
  675. }
  676. else
  677. {
  678. await mainDbService.SetTransactionBillingDone(_request.transactionId, 0, string.Empty);
  679. IBusinessService customer = await businessServiceFactory.CreateBusinessService(session.CustomerId);
  680. var feedto = await mainDbService.GetTransaction(_request.transactionId);
  681. NotifyTransactionCompletedResult response = await customer.NotifyTransactionCompleted(feedto, null);
  682. if (response != null && response.Success)
  683. {
  684. await mainDbService.ReportStopTx(_request.transactionId, response);
  685. }
  686. }
  687. result.Message = confirm;
  688. result.Success = true;
  689. }
  690. dbOpTime = watch.ElapsedMilliseconds;
  691. #region Save MeterValue
  692. if (_request.transactionData != null &&
  693. _request.transactionData.Count > 0)
  694. {
  695. //List<Task> insertTasks = new();
  696. List<InsertMeterValueParam> datas = new();
  697. foreach (var item in _request.transactionData)
  698. {
  699. foreach (var sampleVaule in item.sampledValue)
  700. {
  701. decimal value = Convert.ToDecimal(sampleVaule.value);
  702. datas.Add(new InsertMeterValueParam(
  703. chargeBoxId: session.ChargeBoxId
  704. , connectorId: (byte)_ConnectorId
  705. , value: value
  706. , createdOn: item.timestamp
  707. , contextId: sampleVaule.context.HasValue ? (int)sampleVaule.context : 0
  708. , formatId: sampleVaule.format.HasValue ? (int)sampleVaule.format : 0
  709. , measurandId: sampleVaule.measurand.HasValue ? (int)sampleVaule.measurand : 0
  710. , phaseId: sampleVaule.phase.HasValue ? (int)sampleVaule.phase : 0
  711. , locationId: sampleVaule.location.HasValue ? (int)sampleVaule.location : 0
  712. , unitId: sampleVaule.unit.HasValue ? (int)sampleVaule.unit : 0
  713. , transactionId: _request.transactionId));
  714. //var task = meterValueDbService.InsertAsync(
  715. // chargeBoxId: session.ChargeBoxId
  716. // , connectorId: (byte)_ConnectorId
  717. // , value: value
  718. // , createdOn: item.timestamp
  719. // , contextId: sampleVaule.context.HasValue ? (int)sampleVaule.context : 0
  720. // , formatId: sampleVaule.format.HasValue ? (int)sampleVaule.format : 0
  721. // , measurandId: sampleVaule.measurand.HasValue ? (int)sampleVaule.measurand : 0
  722. // , phaseId: sampleVaule.phase.HasValue ? (int)sampleVaule.phase : 0
  723. // , locationId: sampleVaule.location.HasValue ? (int)sampleVaule.location : 0
  724. // , unitId: sampleVaule.unit.HasValue ? (int)sampleVaule.unit : 0
  725. // , transactionId: _request.transactionId);
  726. //insertTasks.Add(task);
  727. }
  728. }
  729. //await Task.WhenAll(insertTasks);
  730. await meterValueDbService.InsertBundleAsync(datas);
  731. }
  732. #endregion
  733. meterValueTime = watch.ElapsedMilliseconds;
  734. }
  735. catch (Exception ex)
  736. {
  737. result.Exception = new Exception("TransactionId " + _request.transactionId + " " + ex.Message);
  738. result.CallErrorMsg = "Reject Response Message";
  739. result.Success = false;
  740. logger.LogCritical("StopTransaction {msg} trace:{trace}", ex.Message, ex.StackTrace);
  741. // return result;
  742. }
  743. stopTrasactionTimer.Stop();
  744. if (stopTrasactionTimer.ElapsedMilliseconds > 1000)
  745. {
  746. logger.Log(LogLevel.Critical, "ExecuteCoreRequest {action} {ChargeBoxId} took {time} sec", action.ToString(), session.ChargeBoxId, stopTrasactionTimer.ElapsedMilliseconds / 1000);
  747. logger.Log(LogLevel.Critical, "{action} {ChargeBoxId} time {getDateTime}/{serviceTime}/{tagInfoTime}/{dbOpTime}/{meterValueTime}", action.ToString(), session.ChargeBoxId, getDateTimeTime, getServiceTime, getTagInfoTime, dbOpTime, meterValueTime);
  748. }
  749. }
  750. break;
  751. case Actions.Authorize:
  752. {
  753. AuthorizeRequest _request = request as AuthorizeRequest;
  754. var businessService = await businessServiceFactory.CreateBusinessService(session.CustomerId);
  755. var confirm = new AuthorizeConfirmation()
  756. {
  757. idTagInfo = new IdTagInfo() { expiryDate = DateTime.UtcNow.AddDays(1), status = AuthorizationStatus.Accepted }
  758. };
  759. if (_request.idTag != "Backend")
  760. {
  761. var authorization_result = await businessService.Authorize(session.ChargeBoxId, _request.idTag, source: Actions.Authorize.ToString());
  762. confirm.idTagInfo = authorization_result.IdTagInfo;
  763. if (confirm.idTagInfo.status == AuthorizationStatus.Accepted && authorization_result.ChargePointFee != null)
  764. {
  765. var price = authorization_result.ChargePointFee.Where(x => x.IsAC == session.IsAC).First();
  766. if (price != null)
  767. {
  768. session.UserPrices[_request.idTag] = price.PerkWhFee.HasValue ? JsonConvert.SerializeObject(new List<ChargingPrice>() { new ChargingPrice() { StartTime = "00:00", EndTime = "23:59", Fee = price.PerkWhFee.Value } }) : price.PerHourFee.Value.ToString();
  769. session.UserPrices[_request.idTag] += "|+" + authorization_result.AccountBalance + "+" + "&" + price.ParkingFee + "&|" + price.Currency;
  770. session.UserDisplayPrices[_request.idTag] = price.DisplayMessage;
  771. }
  772. }
  773. }
  774. //特例****飛宏客戶旗下的電樁,若遇到Portal沒回應的狀況 ~允許充電
  775. if (session.CustomerId.ToString().ToUpper() == "8456AED9-6DD9-4BF3-A94C-9F5DCB9506F7" && confirm.idTagInfo.status == AuthorizationStatus.ConcurrentTx)
  776. {
  777. confirm.idTagInfo = new IdTagInfo() { expiryDate = DateTime.UtcNow.AddDays(1), status = AuthorizationStatus.Accepted };
  778. }
  779. result.Message = confirm;
  780. result.Success = true;
  781. }
  782. break;
  783. default:
  784. {
  785. logger.LogWarning(string.Format("Not Implement {0} Logic(ExecuteCoreRequest)", request.GetType().ToString().Replace("OCPPPackage.Messages.Core.", "")));
  786. }
  787. break;
  788. }
  789. }
  790. catch (Exception ex)
  791. {
  792. logger.LogCritical("chargeBoxId:{0} {1}", session?.ChargeBoxId, action);
  793. logger.LogCritical("Data {0}", request?.ToString());
  794. logger.LogCritical("Error {0}", ex.ToString());
  795. result.Exception = ex;
  796. }
  797. //if (action == Actions.Heartbeat)
  798. //{
  799. watch.Stop();
  800. if (watch.ElapsedMilliseconds / 1000 > 3)
  801. {
  802. logger.LogError("Processing " + action.ToString() + " costs " + watch.ElapsedMilliseconds / 1000 + " seconds"); ;
  803. }
  804. //}
  805. if (watch.ElapsedMilliseconds > 5_000)
  806. {
  807. //ThreadPool.GetAvailableThreads(out int workerThreads,out int completionThreads);
  808. //logger.LogInformation($"ThreadPool workerThreads:{workerThreads} completionThreads:{completionThreads}");
  809. //await blockingTreePrintService.PrintDbBlockingTree();
  810. //await googleGetTimePrintService.Print();
  811. }
  812. return result;
  813. }
  814. async internal Task<MessageResult> ExecuteCoreConfirm(Actions action, WsClientData session, IConfirmation confirm, string requestId)
  815. {
  816. MessageResult result = new MessageResult() { Success = true };
  817. try
  818. {
  819. switch (action)
  820. {
  821. case Actions.DataTransfer:
  822. {
  823. DataTransferConfirmation _confirm = confirm as DataTransferConfirmation;
  824. DataTransferRequest _request = _confirm.GetRequest() as DataTransferRequest;
  825. await mainDbService.SetMachineOperateRecordFinished(requestId, session.ChargeBoxId, _confirm.status, _confirm.data);
  826. if (_request.messageId == "ID_FirmwareVersion")
  827. {
  828. await mainDbService.RecordBoardVersions(session.MachineId, _confirm.data);
  829. }
  830. if (_request.messageId == "ID_TxEnergy") //計費
  831. {
  832. if (_confirm.status == DataTransferStatus.Accepted)
  833. {
  834. decimal couponPoint = 0m;
  835. string farewellMessage = string.Empty;
  836. string receipt = string.Empty;
  837. List<ChargingBill> bill = new List<ChargingBill>();
  838. List<ChargingPrice> chargingPrices = new List<ChargingPrice>();
  839. var txEnergy = JsonConvert.DeserializeObject<TransactionEnergy>(_confirm.data);
  840. var roundedPeriodEnergy = PeriodEnergyRounding(txEnergy.PeriodEnergy);
  841. //var feedto = await db.TransactionRecord.Where(x => x.Id == txEnergy.TxId).Select(x => new { Id = x.Id, ConnectorId = x.ConnectorId, Fee = x.Fee, StopTime = x.StopTime, StartTime = x.StartTime, NotifyPnC = x.NotifyPnC }).FirstOrDefaultAsync();
  842. var feedto = await mainDbService.GetTransaction(txEnergy.TxId);
  843. decimal chargedEnergy = 0m;
  844. if (feedto == null)
  845. return result;
  846. if (string.IsNullOrEmpty(feedto.Fee))
  847. {
  848. if (feedto.StopTime != GlobalConfig.DefaultNullTime)
  849. {
  850. await mainDbService.InsertOrUpdateTransactionPeriodEnergy(txEnergy.TxId, roundedPeriodEnergy);
  851. await mainDbService.SetTransactionBillingDone(txEnergy.TxId, 0, string.Empty);
  852. IBusinessService customer = await businessServiceFactory.CreateBusinessService(session.CustomerId);
  853. NotifyTransactionCompletedResult response = await customer.NotifyTransactionCompleted(feedto, roundedPeriodEnergy);
  854. if (response != null && response.Success)
  855. {
  856. await mainDbService.ReportStopTx(feedto.Id, response);
  857. }
  858. }
  859. return result;
  860. }
  861. if (feedto == null || string.IsNullOrEmpty(feedto.Fee)) return result;
  862. if (!feedto.NotifyPnC && !string.IsNullOrEmpty(txEnergy.EVCCID))
  863. {
  864. //send PnC notification....
  865. //var customerInfo = db.Customer.Where(x => x.Id == session.CustomerId).Select(x => new { x.InstantStopTxReport, x.ApiUrl, x.ApiKey }).FirstOrDefault();
  866. var customerInfo = await mainDbService.GetCustomer(session.CustomerId);
  867. var request = new
  868. {
  869. SessionId = feedto.Id,
  870. ChargeBoxId = session.ChargeBoxId,
  871. EVCCID = txEnergy.EVCCID
  872. };
  873. logger.LogDebug(customerInfo.ApiUrl + "session_pncinfo=>" + JsonConvert.SerializeObject(request));
  874. var response = await httpClient.Post(customerInfo.ApiUrl + "session_pncinfo", new Dictionary<string, string>()
  875. {
  876. { "PartnerId",session.CustomerId.ToString()}
  877. }, request, customerInfo.ApiKey);
  878. if (response.Status == System.Net.HttpStatusCode.OK)
  879. {
  880. var _httpResult = JsonConvert.DeserializeObject<CPOOuterResponse>(response.Response);
  881. logger.LogDebug("session_pncinfo Response" + JsonConvert.SerializeObject(response));
  882. await mainDbService.SetPncNotifiyResult(txEnergy.TxId, response.Status == System.Net.HttpStatusCode.OK, txEnergy.EVCCID);
  883. }
  884. }
  885. string currency = feedto.Fee.Substring(feedto.Fee.Length - 3);
  886. decimal chargingCost = 0;
  887. if (feedto.Fee.Length > 58)
  888. {
  889. chargingPrices = JsonConvert.DeserializeObject<List<ChargingPrice>>(feedto.Fee.Split('|')[0]);
  890. foreach (var item in roundedPeriodEnergy)
  891. {
  892. DateTime dt = new DateTime(2021, 01, 01, int.Parse(item.Key), 0, 0, DateTimeKind.Utc);
  893. string startTime = dt.ToString("hh:mm tt", new CultureInfo("en-us"));
  894. decimal perfee = 0;
  895. // 小數點第5位4捨五入
  896. //var periodEnergy = PeriodEnergyRounding(item.Value);
  897. var periodEnergy = item.Value;
  898. chargedEnergy += periodEnergy;
  899. if (chargingPrices.Count == 1)
  900. {
  901. perfee = Decimal.Multiply(periodEnergy, chargingPrices[0].Fee);
  902. if (bill.Count == 0)
  903. {
  904. bill.Add(new ChargingBill()
  905. {
  906. StartTime = "12:00 AM",
  907. EndTime = "11:59 PM",
  908. Fee = chargingPrices[0].Fee
  909. });
  910. }
  911. bill[0].PeriodEnergy += periodEnergy;
  912. }
  913. else
  914. {
  915. var price = chargingPrices.Where(x => x.StartTime == startTime).FirstOrDefault();
  916. perfee = Decimal.Multiply(periodEnergy, price.Fee);
  917. bill.Add(new ChargingBill()
  918. {
  919. StartTime = price.StartTime,
  920. EndTime = price.EndTime,
  921. PeriodEnergy = periodEnergy,
  922. Fee = price.Fee,
  923. });
  924. }
  925. if (bill.Count > 0)
  926. {
  927. bill[bill.Count - 1].Total += DollarRounding(perfee, session.Currency);
  928. chargingCost += bill[bill.Count - 1].Total;
  929. if (bill.Count == 1)
  930. {
  931. bill[bill.Count - 1].Total = DollarRounding(Decimal.Multiply(bill[0].PeriodEnergy, bill[0].Fee), session.Currency);
  932. chargingCost = bill[bill.Count - 1].Total;
  933. }
  934. }
  935. }
  936. }
  937. else
  938. {
  939. //以小時計費
  940. foreach (var periodEnergy in roundedPeriodEnergy)
  941. {
  942. // 小數點第5位4捨五入
  943. //var periodEnergy = PeriodEnergyRounding(item.Value);
  944. chargedEnergy += periodEnergy.Value;
  945. }
  946. var fee = decimal.Parse(feedto.Fee.Split('|')[0]);
  947. var charging_stoptime = feedto.StopTime == GlobalConfig.DefaultNullTime ? DateTime.Parse(DateTime.UtcNow.ToString("yyyy/MM/dd HH:mm")) : DateTime.Parse(feedto.StopTime.ToString("yyyy/MM/dd HH:mm"));
  948. var charging_starttime = DateTime.Parse(feedto.StartTime.ToString("yyyy/MM/dd HH:mm"));
  949. chargingCost = Decimal.Multiply((decimal)charging_stoptime.Subtract(charging_starttime).TotalHours, fee);
  950. chargingCost = DollarRounding(chargingCost, session.Currency);
  951. }
  952. // 計算停車費
  953. var parkingFee = decimal.Parse(feedto.Fee.Split('&')[1]);
  954. var stoptime = feedto.StopTime == GlobalConfig.DefaultNullTime ? DateTime.Parse(DateTime.UtcNow.ToString("yyyy/MM/dd HH:mm")) : DateTime.Parse(feedto.StopTime.ToString("yyyy/MM/dd HH:mm"));
  955. var starttime = DateTime.Parse(feedto.StartTime.ToString("yyyy/MM/dd HH:mm"));
  956. var totalHours = stoptime.Subtract(starttime).TotalHours;
  957. var parkingCost = Decimal.Multiply((decimal)totalHours, parkingFee);
  958. parkingCost = DollarRounding(parkingCost, session.Currency);
  959. if (feedto.StopTime != GlobalConfig.DefaultNullTime)
  960. {
  961. //var customerInfo = await db.Customer
  962. // .Where(x => x.Id == session.CustomerId).Select(x => new { x.InstantStopTxReport, x.ApiUrl, x.ApiKey })
  963. // .FirstOrDefaultAsync();
  964. //var customerInfo = await mainDbService.GetCustomer(session.CustomerId);
  965. IBusinessService customer = await businessServiceFactory.CreateBusinessService(session.CustomerId);
  966. decimal accountBalance = 0;
  967. decimal.TryParse(feedto.Fee.Split('+')[1], out accountBalance);
  968. //var tx = await db.TransactionRecord.Where(x => x.Id == txEnergy.TxId).FirstOrDefaultAsync();
  969. var tx = await mainDbService.GetTransaction(txEnergy.TxId);
  970. if (tx == null)
  971. {
  972. logger.LogWarning("Tx is empty");
  973. return result;
  974. }
  975. if (tx.BillingDone) return result;
  976. if (feedto.StopTime != DefaultSetting.DefaultNullTime)
  977. {
  978. await mainDbService.InsertOrUpdateTransactionPeriodEnergy(txEnergy.TxId, roundedPeriodEnergy);
  979. }
  980. var startTime = new DateTime(tx.StartTime.Year, tx.StartTime.Month, tx.StartTime.Day, tx.StartTime.Hour, 0, 0);
  981. List<ChargingBill> confirmbill = new List<ChargingBill>();
  982. receipt = string.Format("({0} )Energy:", chargedEnergy);
  983. while (startTime < tx.StopTime)
  984. {
  985. if (bill.Count == 1)
  986. {
  987. confirmbill = bill;
  988. receipt += string.Format("| {0} - {1}:| {2} kWh @ ${3}/kWh= ${4}", tx.StartTime.ToString("hh:mm tt", new CultureInfo("en-us")), tx.StopTime.ToString("hh:mm tt", new CultureInfo("en-us")),
  989. confirmbill[0].PeriodEnergy.ToString("0.0000"), bill[0].Fee, bill[0].Total);
  990. break;
  991. }
  992. if (bill.Count == 0)
  993. {
  994. receipt += string.Format("| {0} - {1} @ ${2}/hr= ${3}", feedto.StartTime.ToString("hh:mm tt", new CultureInfo("en-us")),
  995. feedto.StopTime.ToString("hh:mm tt", new CultureInfo("en-us")), feedto.Fee.Split('|')[0], chargingCost);
  996. break;
  997. }
  998. if (bill.Count > 1)
  999. {
  1000. var time = startTime.ToString("hh:mm tt", new CultureInfo("en-us"));
  1001. var tt = bill.Where(x => x.StartTime == time).FirstOrDefault();
  1002. confirmbill.Add(tt);
  1003. if (confirmbill.Count == 1)
  1004. {
  1005. confirmbill[0].StartTime = tx.StartTime.ToString("hh:mm tt", new CultureInfo("en-us"));
  1006. }
  1007. var stopTimeText = tx.StopTime.ToString("hh:mm tt", new CultureInfo("en-us"));
  1008. if (confirmbill[confirmbill.Count - 1].StartTime.Contains(stopTimeText.Split(' ')[1]))
  1009. {
  1010. var subHourText = (int.Parse(stopTimeText.Split(':')[0])).ToString();
  1011. subHourText = subHourText.Length == 1 ? "0" + subHourText : subHourText;
  1012. if (confirmbill[confirmbill.Count - 1].StartTime.Contains(subHourText))
  1013. {
  1014. confirmbill[confirmbill.Count - 1].EndTime = stopTimeText;
  1015. }
  1016. }
  1017. receipt += string.Format("| {0} - {1}:| {2} kWh @ ${3}/kWh= ${4}", confirmbill[confirmbill.Count - 1].StartTime, confirmbill[confirmbill.Count - 1].EndTime,
  1018. confirmbill[confirmbill.Count - 1].PeriodEnergy.ToString("0.0000"), confirmbill[confirmbill.Count - 1].Fee, confirmbill[confirmbill.Count - 1].Total);
  1019. if (confirmbill.Count == 24) break;
  1020. }
  1021. startTime = startTime.AddHours(1);
  1022. }
  1023. chargingCost = confirmbill.Count > 0 ? confirmbill.Sum(x => x.Total) : chargingCost;
  1024. receipt += string.Format("|Total Energy Fee : ${0}", chargingCost);
  1025. receipt += string.Format("|Parking Fee: | {0} - {1}: | {2} @ ${3}/hr= ${4}", feedto.StartTime.ToString("hh:mm tt", new CultureInfo("en-us")),
  1026. feedto.StopTime.ToString("hh:mm tt", new CultureInfo("en-us")), (totalHours / 1 >= 1) ? string.Format("{0} hours {1} minutes", (int)totalHours / 1, ((totalHours % 1) * 60).ToString("0.0")) : string.Format("{0} minutes", ((totalHours % 1) * 60).ToString("0.0")), parkingFee, parkingCost);
  1027. receipt += string.Format("|Stop Reason: {0}", tx.StopReason);
  1028. //tx.Cost = chargingCost + parkingCost;
  1029. await mainDbService.SetTransactionBillingDone(txEnergy.TxId, cost: chargingCost + parkingCost, receipt);
  1030. tx = await mainDbService.GetTransaction(txEnergy.TxId);
  1031. var response = await customer.NotifyTransactionCompleted(tx, roundedPeriodEnergy);
  1032. if (response != null)
  1033. {
  1034. couponPoint = response.CouponPoint == null ? couponPoint : response.CouponPoint.Value;
  1035. farewellMessage = response.FarewellMessage == null ? farewellMessage : response.FarewellMessage;
  1036. if (response.Success)
  1037. {
  1038. await mainDbService.ReportStopTx(feedto.Id, response);
  1039. }
  1040. }
  1041. await messageService.SendDataTransferRequest(
  1042. session.ChargeBoxId,
  1043. messageId: "FinalCost",
  1044. vendorId: "Phihong Technology",
  1045. data: JsonConvert.SerializeObject(new
  1046. {
  1047. txId = txEnergy.TxId,
  1048. description = JsonConvert.SerializeObject(new
  1049. {
  1050. chargedEnergy = chargedEnergy,
  1051. chargingFee = chargingCost,
  1052. parkTime = (int)stoptime.Subtract(starttime).TotalSeconds,
  1053. parkingFee = parkingCost,
  1054. currency = currency,
  1055. couponPoint = couponPoint,
  1056. accountBalance = accountBalance - tx.Cost,
  1057. farewellMessage = farewellMessage
  1058. })
  1059. })
  1060. );
  1061. await meterValueDbService.InsertAsync(
  1062. chargeBoxId: session.ChargeBoxId,
  1063. connectorId: feedto.ConnectorId,
  1064. value: chargingCost,
  1065. createdOn: DateTime.UtcNow,
  1066. contextId: (int)ReadingContext.Sample_Periodic,
  1067. formatId: (int)ValueFormat.Raw,
  1068. measurandId: (int)Measurand.TotalCost,
  1069. phaseId: -1,
  1070. locationId: -1,
  1071. unitId: -1,
  1072. transactionId: feedto.Id);
  1073. using (SqlConnection conn = await webDbConnectionFactory.CreateAsync())
  1074. {
  1075. var parameters = new DynamicParameters();
  1076. parameters.Add("@IdTag", tx.StartIdTag, DbType.String, ParameterDirection.Input, 50);
  1077. parameters.Add("@parentIdTag", accountBalance - tx.Cost, DbType.String, ParameterDirection.Input, 50);
  1078. string strSql = "update [dbo].[LocalListDetail] set parentIdTag =@parentIdTag where ListId = 27 and IdTag=@IdTag; ";
  1079. await conn.ExecuteAsync(strSql, parameters);
  1080. }
  1081. #region 提供給PHA 過CDFA認證 使用
  1082. if (tx.CustomerId == Guid.Parse("10C7F5BD-C89A-4E2A-8611-B617E0B41A73"))
  1083. {
  1084. var mail_response = httpClient.PostFormDataAsync("https://charge.zerovatech.com/CDFA/" + tx.Id, new Dictionary<string, string>()
  1085. {
  1086. { "email","2"},
  1087. { "to","wonderj@phihongusa.com;jessica_tseng@phihong.com.tw"}
  1088. //{ "to","jessica_tseng@phihong.com.tw"}
  1089. }, null);
  1090. logger.LogTrace(JsonConvert.SerializeObject(mail_response));
  1091. }
  1092. #endregion
  1093. }
  1094. else
  1095. {
  1096. await messageService.SendDataTransferRequest(
  1097. session.ChargeBoxId,
  1098. messageId: "RunningCost",
  1099. vendorId: "Phihong Technology",
  1100. data: JsonConvert.SerializeObject(new
  1101. {
  1102. txId = txEnergy.TxId,
  1103. description = JsonConvert.SerializeObject(new
  1104. {
  1105. chargedEnergy = chargedEnergy,
  1106. chargingFee = chargingCost,
  1107. parkTime = (int)stoptime.Subtract(starttime).TotalSeconds,
  1108. parkingFee = parkingCost,
  1109. currency = currency
  1110. })
  1111. })
  1112. );
  1113. await meterValueDbService.InsertAsync(
  1114. chargeBoxId: session.ChargeBoxId,
  1115. connectorId: (byte)feedto.ConnectorId,
  1116. value: chargingCost,
  1117. createdOn: DateTime.UtcNow,
  1118. contextId: (int)ReadingContext.Sample_Periodic,
  1119. formatId: (int)ValueFormat.Raw,
  1120. measurandId: (int)Measurand.ChargingCost,
  1121. phaseId: -1,
  1122. locationId: -1,
  1123. unitId: -1,
  1124. transactionId: feedto.Id
  1125. );
  1126. }
  1127. }
  1128. }
  1129. using (var db = await maindbContextFactory.CreateDbContextAsync())
  1130. {
  1131. #region 台泥
  1132. if (_request.messageId == "ID_GetTxUserInfo")
  1133. {
  1134. var txUserInfo = JsonConvert.DeserializeObject<ID_GetTxUserInfo>(_confirm.data);
  1135. if (session.CustomerId == new Guid("009E603C-79CD-4620-A2B8-D9349C0E8AD8"))
  1136. {
  1137. var request = new
  1138. {
  1139. ChargeBoxId = session.ChargeBoxId,
  1140. ConnectorId = txUserInfo.ConnectorId,
  1141. SessionId = txUserInfo.TxId,
  1142. SerialNo = txUserInfo.SerialNo,
  1143. StartTime = txUserInfo.StartTime.ToString(GlobalConfig.UTC_DATETIMEFORMAT),
  1144. VEMData = txUserInfo.VEMData
  1145. };
  1146. var response = httpClient.Post(GlobalConfig.TCC_API_URL + "start_session", new Dictionary<string, string>()
  1147. {
  1148. { "PartnerId",session.CustomerId.ToString()}
  1149. }, request, GlobalConfig.TCC_SALTKEY);
  1150. logger.LogDebug(JsonConvert.SerializeObject(response));
  1151. }
  1152. }
  1153. #endregion
  1154. }
  1155. }
  1156. break;
  1157. case Actions.ChangeAvailability:
  1158. {
  1159. ChangeAvailabilityConfirmation _confirm = confirm as ChangeAvailabilityConfirmation;
  1160. ChangeAvailabilityRequest _request = _confirm.GetRequest() as ChangeAvailabilityRequest;
  1161. using (var db = await maindbContextFactory.CreateDbContextAsync())
  1162. {
  1163. var operation = await db.MachineOperateRecord.Where(x => x.SerialNo == requestId &&
  1164. x.ChargeBoxId == session.ChargeBoxId && x.Status == 0).FirstOrDefaultAsync();
  1165. if (operation != null)
  1166. {
  1167. operation.FinishedOn = DateTime.UtcNow;
  1168. operation.Status = 1;//電樁有回覆
  1169. operation.EvseStatus = (int)_confirm.status;
  1170. operation.EvseValue = _confirm.status.ToString();
  1171. await db.SaveChangesAsync();
  1172. }
  1173. }
  1174. }
  1175. break;
  1176. case Actions.ClearCache:
  1177. {
  1178. ClearCacheConfirmation _confirm = confirm as ClearCacheConfirmation;
  1179. ClearCacheRequest _request = _confirm.GetRequest() as ClearCacheRequest;
  1180. using (var db = await maindbContextFactory.CreateDbContextAsync())
  1181. {
  1182. var operation = await db.MachineOperateRecord.Where(x => x.SerialNo == requestId &&
  1183. x.ChargeBoxId == session.ChargeBoxId && x.Status == 0).FirstOrDefaultAsync();
  1184. if (operation != null)
  1185. {
  1186. operation.FinishedOn = DateTime.UtcNow;
  1187. operation.Status = 1;//電樁有回覆
  1188. operation.EvseStatus = (int)_confirm.status;
  1189. operation.EvseValue = _confirm.status.ToString();
  1190. await db.SaveChangesAsync();
  1191. }
  1192. }
  1193. }
  1194. break;
  1195. case Actions.RemoteStartTransaction:
  1196. {
  1197. RemoteStartTransactionConfirmation _confirm = confirm as RemoteStartTransactionConfirmation;
  1198. RemoteStartTransactionRequest _request = _confirm.GetRequest() as RemoteStartTransactionRequest;
  1199. using (var db = await maindbContextFactory.CreateDbContextAsync())
  1200. {
  1201. var operation = await db.MachineOperateRecord.Where(x => x.SerialNo == requestId &&
  1202. x.ChargeBoxId == session.ChargeBoxId && x.Status == 0).FirstOrDefaultAsync();
  1203. if (operation != null)
  1204. {
  1205. operation.FinishedOn = DateTime.UtcNow;
  1206. operation.Status = 1;//電樁有回覆
  1207. operation.EvseStatus = (int)_confirm.status;
  1208. operation.EvseValue = _confirm.status.ToString();
  1209. await db.SaveChangesAsync();
  1210. }
  1211. }
  1212. }
  1213. break;
  1214. case Actions.RemoteStopTransaction:
  1215. {
  1216. RemoteStopTransactionConfirmation _confirm = confirm as RemoteStopTransactionConfirmation;
  1217. RemoteStopTransactionRequest _request = _confirm.GetRequest() as RemoteStopTransactionRequest;
  1218. using (var db = await maindbContextFactory.CreateDbContextAsync())
  1219. {
  1220. var operation = await db.MachineOperateRecord.Where(x => x.SerialNo == requestId &&
  1221. x.ChargeBoxId == session.ChargeBoxId && x.Status == 0).FirstOrDefaultAsync();
  1222. if (operation != null)
  1223. {
  1224. operation.FinishedOn = DateTime.UtcNow;
  1225. operation.Status = 1;//電樁有回覆
  1226. operation.EvseStatus = (int)_confirm.status;
  1227. operation.EvseValue = _confirm.status.ToString();
  1228. await db.SaveChangesAsync();
  1229. }
  1230. }
  1231. }
  1232. break;
  1233. case Actions.Reset:
  1234. {
  1235. ResetConfirmation _confirm = confirm as ResetConfirmation;
  1236. ResetRequest _request = _confirm.GetRequest() as ResetRequest;
  1237. using (var db = await maindbContextFactory.CreateDbContextAsync())
  1238. {
  1239. var operation = await db.MachineOperateRecord.Where(x => x.SerialNo == requestId &&
  1240. x.ChargeBoxId == session.ChargeBoxId && x.Status == 0).FirstOrDefaultAsync();
  1241. if (operation != null)
  1242. {
  1243. operation.FinishedOn = DateTime.UtcNow;
  1244. operation.Status = 1;//電樁有回覆
  1245. operation.EvseStatus = (int)_confirm.status;
  1246. operation.EvseValue = _confirm.status.ToString();
  1247. await db.SaveChangesAsync();
  1248. }
  1249. }
  1250. }
  1251. break;
  1252. case Actions.ChangeConfiguration:
  1253. {
  1254. ChangeConfigurationConfirmation _confirm = confirm as ChangeConfigurationConfirmation;
  1255. ChangeConfigurationRequest _request = _confirm.GetRequest() as ChangeConfigurationRequest;
  1256. using (var db = await maindbContextFactory.CreateDbContextAsync())
  1257. {
  1258. var operation = await db.MachineOperateRecord.Where(x => x.SerialNo == requestId &&
  1259. x.ChargeBoxId == session.ChargeBoxId && x.Status == 0).FirstOrDefaultAsync();
  1260. if (operation != null)
  1261. {
  1262. operation.FinishedOn = DateTime.UtcNow;
  1263. operation.Status = 1;//電樁有回覆
  1264. operation.EvseStatus = (int)_confirm.status;
  1265. operation.EvseValue = _confirm.status.ToString();
  1266. }
  1267. if (_confirm.status == Packet.Messages.SubTypes.ConfigurationStatus.Accepted || _confirm.status == Packet.Messages.SubTypes.ConfigurationStatus.RebootRequired)
  1268. {
  1269. var configure = await db.MachineConfigurations.Where(x => x.ChargeBoxId == session.ChargeBoxId).ToListAsync();
  1270. var foundConfig = configure.Find(x => x.ConfigureName == _request.key);
  1271. if (foundConfig != null)
  1272. {
  1273. foundConfig.ReadOnly = false;
  1274. foundConfig.ConfigureSetting = _request.value;
  1275. }
  1276. else
  1277. {
  1278. await db.MachineConfigurations.AddAsync(new MachineConfigurations()
  1279. {
  1280. ChargeBoxId = session.ChargeBoxId,
  1281. ConfigureName = _request.key,
  1282. ReadOnly = false,
  1283. ConfigureSetting = _request.value
  1284. });
  1285. }
  1286. }
  1287. await db.SaveChangesAsync();
  1288. }
  1289. }
  1290. break;
  1291. case Actions.GetConfiguration:
  1292. {
  1293. try
  1294. {
  1295. GetConfigurationConfirmation _confirm = confirm as GetConfigurationConfirmation;
  1296. List<MachineConfigurations> configure = await mainDbService.GetMachineConfiguration(session.ChargeBoxId);
  1297. string customId = string.Empty;
  1298. if (_confirm.configurationKey != null)
  1299. {
  1300. foreach (var item in _confirm.configurationKey)
  1301. {
  1302. string oldValue = string.Empty;
  1303. if (item.key == null)
  1304. {
  1305. logger.LogTrace("*********************");
  1306. }
  1307. var foundConfig = configure.Find(x => x.ConfigureName == item.key);
  1308. var updateValue = string.IsNullOrEmpty(item.value) ? string.Empty : item.value;
  1309. if (item.key == "CentralChargeBoxId" || item.key == "ChargeBoxId")
  1310. {
  1311. customId = item.value;
  1312. }
  1313. if (foundConfig == null)
  1314. {
  1315. await mainDbService.AddMachineConfiguration(session.ChargeBoxId, item.key, updateValue, item.IsReadOnly);
  1316. }
  1317. else if (item.value != foundConfig.ConfigureSetting)
  1318. {
  1319. if (foundConfig.ConfigureName == null)
  1320. {
  1321. logger.LogTrace("*********************");
  1322. }
  1323. if (foundConfig.ConfigureName == "SecurityProfile")
  1324. {
  1325. oldValue = foundConfig.ConfigureSetting;
  1326. }
  1327. await mainDbService.UpdateMachineConfiguration(session.ChargeBoxId, item.key, updateValue, item.IsReadOnly);
  1328. }
  1329. }
  1330. }
  1331. if (_confirm.unknownKey != null)
  1332. {
  1333. foreach (var item in _confirm.unknownKey)
  1334. {
  1335. var foundConfig = configure.Find(x => x.ConfigureName == item);
  1336. if (foundConfig != null)
  1337. {
  1338. await mainDbService.UpdateMachineConfiguration(session.ChargeBoxId, item, string.Empty, isReadOnly: true, isExists: false);
  1339. }
  1340. else
  1341. {
  1342. await mainDbService.AddMachineConfiguration(session.ChargeBoxId, item, string.Empty, isReadOnly: true, isExist: false);
  1343. }
  1344. }
  1345. }
  1346. using (var db = await maindbContextFactory.CreateDbContextAsync())
  1347. {
  1348. var operation = await db.MachineOperateRecord.Where(x => x.SerialNo == requestId &&
  1349. x.ChargeBoxId == session.ChargeBoxId && x.Status == 0).FirstOrDefaultAsync();
  1350. if (operation != null)
  1351. {
  1352. operation.FinishedOn = DateTime.UtcNow;
  1353. operation.Status = 1;//電樁有回覆
  1354. operation.EvseStatus = 1;
  1355. operation.EvseValue = JsonConvert.SerializeObject(_confirm.configurationKey, Formatting.None);
  1356. }
  1357. await db.SaveChangesAsync();
  1358. }
  1359. if (!string.IsNullOrEmpty(customId))
  1360. {
  1361. await mainDbService.UpdateCustomId(customId, session.ChargeBoxId);
  1362. }
  1363. }
  1364. catch (Exception ex)
  1365. {
  1366. logger.LogError(ex.ToString());
  1367. }
  1368. }
  1369. break;
  1370. case Actions.UnlockConnector:
  1371. {
  1372. UnlockConnectorConfirmation _confirm = confirm as UnlockConnectorConfirmation;
  1373. UnlockConnectorRequest _request = _confirm.GetRequest() as UnlockConnectorRequest;
  1374. using (var db = await maindbContextFactory.CreateDbContextAsync())
  1375. {
  1376. var operation = await db.MachineOperateRecord.Where(x => x.SerialNo == requestId &&
  1377. x.ChargeBoxId == session.ChargeBoxId && x.Status == 0).FirstOrDefaultAsync();
  1378. if (operation != null)
  1379. {
  1380. operation.FinishedOn = DateTime.UtcNow;
  1381. operation.Status = 1;//電樁有回覆
  1382. operation.EvseStatus = (int)_confirm.status;
  1383. operation.EvseValue = _confirm.status.ToString();
  1384. await db.SaveChangesAsync();
  1385. }
  1386. }
  1387. }
  1388. break;
  1389. default:
  1390. {
  1391. logger.LogWarning(string.Format("Not Implement {0} Logic(ExecuteCoreConfirm)", confirm.GetType().ToString().Replace("OCPPPackage.Messages.Core.", "")));
  1392. }
  1393. break;
  1394. }
  1395. }
  1396. catch (Exception ex)
  1397. {
  1398. logger.LogDebug("123 " + action + " " + ex.ToString());
  1399. }
  1400. return result;
  1401. }
  1402. internal async Task<MessageResult> ReceivedCoreError(Actions action, string errorMsg, WsClientData session, string requestId)
  1403. {
  1404. MessageResult result = new MessageResult() { Success = true };
  1405. switch (action)
  1406. {
  1407. case Actions.ChangeAvailability:
  1408. case Actions.ChangeConfiguration:
  1409. case Actions.ClearCache:
  1410. case Actions.RemoteStartTransaction:
  1411. case Actions.RemoteStopTransaction:
  1412. case Actions.Reset:
  1413. case Actions.GetConfiguration:
  1414. case Actions.UnlockConnector:
  1415. case Actions.DataTransfer:
  1416. {
  1417. if (action == Actions.DataTransfer)
  1418. {
  1419. logger.LogDebug(string.Format("DataTransfer Error {0}: {1}", session.ChargeBoxId, requestId));
  1420. }
  1421. using (var db = await maindbContextFactory.CreateDbContextAsync())
  1422. {
  1423. var operation = await db.MachineOperateRecord.Where(x => x.SerialNo == requestId &&
  1424. x.ChargeBoxId == session.ChargeBoxId && x.Status == 0).FirstOrDefaultAsync();
  1425. if (operation != null)
  1426. {
  1427. operation.FinishedOn = DateTime.UtcNow;
  1428. operation.Status = 1;//電樁有回覆
  1429. operation.EvseStatus = (int)255;//錯誤
  1430. operation.EvseValue = errorMsg;
  1431. await db.SaveChangesAsync();
  1432. }
  1433. }
  1434. }
  1435. break;
  1436. default:
  1437. {
  1438. logger.LogWarning(string.Format("Not Implement {0} Logic(ReceivedCoreError)", action));
  1439. }
  1440. break;
  1441. }
  1442. return result;
  1443. }
  1444. /// <summary>
  1445. /// 依據幣值處理4捨5入
  1446. /// </summary>
  1447. /// <param name="money"></param>
  1448. /// <param name="currency"></param>
  1449. /// <returns></returns>
  1450. private decimal DollarRounding(decimal money, string currency)
  1451. {
  1452. if (currency == "USD" || currency == "EUR")
  1453. {
  1454. //0.4867
  1455. if ((double)((int)(money * 100) + 0.5) <= (double)(money * 100))
  1456. {
  1457. //money = Decimal.Add(money, (decimal)0.01);//0.4967
  1458. }
  1459. money = Math.Round(money, 2, MidpointRounding.AwayFromZero);
  1460. money = Decimal.Parse(money.ToString("0.00"));
  1461. }
  1462. else
  1463. {
  1464. if ((double)((int)(money) + 0.5) <= (double)money)
  1465. {
  1466. // money = (int) money + 1;
  1467. }
  1468. money = Math.Round(money, 0, MidpointRounding.AwayFromZero);
  1469. money = Decimal.Parse(money.ToString("0"));
  1470. }
  1471. return money;
  1472. }
  1473. /// <summary>
  1474. /// PeriodEnergy處理4捨5入
  1475. /// </summary>
  1476. /// <param name="money"></param>
  1477. /// <param name="currency"></param>
  1478. /// <returns></returns>
  1479. private decimal PeriodEnergyRounding(decimal energy)
  1480. {
  1481. energy = Math.Round(energy, 4, MidpointRounding.AwayFromZero);
  1482. energy = Decimal.Parse(energy.ToString("0.0000"));
  1483. return energy;
  1484. }
  1485. /// <summary>
  1486. /// PeriodEnergy處理4捨5入
  1487. /// </summary>
  1488. /// <param name="periodEnergy">raw data of periodEnergy</param>
  1489. /// <returns></returns>
  1490. private Dictionary<string, decimal> PeriodEnergyRounding(Dictionary<string, decimal> periodEnergy)
  1491. {
  1492. var toReturn = new Dictionary<string, decimal>();
  1493. foreach (var period in periodEnergy)
  1494. {
  1495. toReturn.Add(period.Key, PeriodEnergyRounding(period.Value));
  1496. }
  1497. return toReturn;
  1498. }
  1499. private static bool CheckNeedAddMachineError(StatusNotificationRequest _request, ConnectorStatus _oldStatus)
  1500. {
  1501. if (_request.status != ChargePointStatus.Faulted)
  1502. {
  1503. return false;
  1504. }
  1505. bool isNeedAddMachineError = false;
  1506. if (_oldStatus == null)
  1507. isNeedAddMachineError = true;
  1508. if (_oldStatus != null)
  1509. {
  1510. if (_oldStatus.Status != (int)ChargePointStatus.Faulted)
  1511. {
  1512. isNeedAddMachineError = true;
  1513. }
  1514. else if (_oldStatus.ChargePointErrorCodeId != (int)_request.errorCode || _oldStatus.VendorErrorCode != _request.vendorErrorCode)
  1515. {
  1516. isNeedAddMachineError = true;
  1517. }
  1518. }
  1519. return isNeedAddMachineError;
  1520. }
  1521. }