CoreProfileHandler.cs 92 KB

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