FirmwareManagementProfileHandler.cs 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232
  1. using EVCB_OCPP.Domain;
  2. using EVCB_OCPP.Domain.Models.Database;
  3. using EVCB_OCPP.Packet.Features;
  4. using EVCB_OCPP.Packet.Messages;
  5. using EVCB_OCPP.Packet.Messages.FirmwareManagement;
  6. using Newtonsoft.Json;
  7. using OCPPServer.Protocol;
  8. using System;
  9. using System.Linq;
  10. using Microsoft.Extensions.Logging;
  11. using System.Threading.Tasks;
  12. using Microsoft.EntityFrameworkCore;
  13. using EVCB_OCPP.WSServer.Service.WsService;
  14. namespace EVCB_OCPP.WSServer.Message
  15. {
  16. internal partial class ProfileHandler
  17. {
  18. internal async Task<MessageResult> ExecuteFirmwareManagementRequest(Actions action, WsClientData session, IRequest request)
  19. {
  20. MessageResult result = new MessageResult() { Success = false };
  21. try
  22. {
  23. switch (action)
  24. {
  25. case Actions.FirmwareStatusNotification:
  26. {
  27. FirmwareStatusNotificationRequest _request = request as FirmwareStatusNotificationRequest;
  28. if (_request.status == Packet.Messages.SubTypes.FirmwareStatus.Idle)
  29. {
  30. string requestId = Guid.NewGuid().ToString();
  31. using (var db = await maindbContextFactory.CreateDbContextAsync())
  32. {
  33. var machine = await db.Machine.Where(x => x.FW_AssignedVersion.HasValue == true && x.FW_AssignedVersion.HasValue
  34. && x.FW_AssignedVersion != x.FW_VersionReport && x.ChargeBoxId == session.ChargeBoxId)
  35. .Select(x => new { x.Id, x.FW_AssignedVersion }).AsNoTracking().FirstOrDefaultAsync();
  36. if (machine != null)
  37. {
  38. var mv = db.MachineVersionFile.Include(c => c.UploadFile)
  39. .Where(c => c.Id == machine.FW_AssignedVersion.Value).First();
  40. string downloadUrl = mv.UploadFile.FileUrl;
  41. var _updateFWrequest = new UpdateFirmwareRequest()
  42. {
  43. location = new Uri(downloadUrl),
  44. retries = 3,
  45. retrieveDate = DateTime.UtcNow,
  46. retryInterval = 10
  47. };
  48. await db.MachineOperateRecord.AddAsync(new MachineOperateRecord()
  49. {
  50. CreatedOn = DateTime.UtcNow,
  51. ChargeBoxId = session.ChargeBoxId,
  52. SerialNo = requestId,
  53. RequestContent = JsonConvert.SerializeObject(_updateFWrequest, new JsonSerializerSettings() { NullValueHandling = NullValueHandling.Ignore, Formatting = Formatting.None }),
  54. EVSE_Status = 0,
  55. EVSE_Value = "Fw Version:" + machine.FW_AssignedVersion,
  56. Status = 0,
  57. RequestType = 0,
  58. Action = _updateFWrequest.Action.ToString()
  59. });
  60. await db.SaveChangesAsync();
  61. await mainDbService.AddServerMessage(
  62. ChargeBoxId: session.ChargeBoxId,
  63. OutAction: _updateFWrequest.Action.ToString(),
  64. OutRequest: _updateFWrequest,
  65. SerialNo: requestId);
  66. var clearMachine = await db.Machine.Where(x => x.Id == machine.Id).FirstOrDefaultAsync();
  67. clearMachine.FW_AssignedVersion = null;
  68. await db.SaveChangesAsync();
  69. }
  70. }
  71. }
  72. else
  73. {
  74. using (var db = await maindbContextFactory.CreateDbContextAsync())
  75. {
  76. var item = await db.MachineOperateRecord.Where(x => x.ChargeBoxId == session.ChargeBoxId && x.Action == "UpdateFirmware" && x.RequestType == 0)
  77. .OrderByDescending(x => x.CreatedOn).FirstOrDefaultAsync();
  78. if (item != null)
  79. {
  80. item.EVSE_Status = (int)_request.status;
  81. item.FinishedOn = DateTime.UtcNow;
  82. }
  83. await db.SaveChangesAsync();
  84. }
  85. }
  86. var confirm = new FirmwareStatusNotificationConfirmation() { };
  87. result.Message = confirm;
  88. result.Success = true;
  89. }
  90. break;
  91. case Actions.DiagnosticsStatusNotification:
  92. {
  93. DiagnosticsStatusNotificationRequest _request = request as DiagnosticsStatusNotificationRequest;
  94. if (_request.status != Packet.Messages.SubTypes.DiagnosticsStatus.Idle)
  95. {
  96. using (var db = await maindbContextFactory.CreateDbContextAsync())
  97. {
  98. var item = db.MachineOperateRecord.Where(x => x.ChargeBoxId == session.ChargeBoxId && x.Action == "GetDiagnostics" && x.RequestType == 1)
  99. .OrderByDescending(x => x.CreatedOn).FirstOrDefault();
  100. if (item != null)
  101. {
  102. item.EVSE_Status = (int)_request.status;
  103. item.FinishedOn = DateTime.UtcNow;
  104. }
  105. await db.SaveChangesAsync();
  106. }
  107. }
  108. var confirm = new DiagnosticsStatusNotificationConfirmation() { };
  109. result.Message = confirm;
  110. result.Success = true;
  111. }
  112. break;
  113. default:
  114. {
  115. logger.LogWarning(string.Format("Not Implement {0} Logic", request.GetType().ToString().Replace("OCPPPackage.Messages.FirmwareManagement.", "")));
  116. }
  117. break;
  118. }
  119. }
  120. catch (Exception ex)
  121. {
  122. logger.LogCritical("chargeBoxId:{0} {1}", session.ChargeBoxId, action);
  123. logger.LogCritical("Data {0}", request.ToString());
  124. logger.LogCritical("Error {0}", ex.ToString());
  125. result.Exception = ex;
  126. }
  127. return result;
  128. }
  129. internal async Task<MessageResult> ExecuteFirmwareManagementConfirm(Actions action, WsClientData session, IConfirmation confirm, string requestId)
  130. {
  131. MessageResult result = new MessageResult() { Success = true };
  132. switch (action)
  133. {
  134. case Actions.UpdateFirmware:
  135. case Actions.GetDiagnostics:
  136. {
  137. string evse_rep = string.Empty;
  138. if (confirm is GetDiagnosticsConfirmation)
  139. {
  140. var confirmation = confirm as GetDiagnosticsConfirmation;
  141. evse_rep = confirmation.fileName;
  142. }
  143. using (var db = await maindbContextFactory.CreateDbContextAsync())
  144. {
  145. var operation = await db.MachineOperateRecord
  146. .Where(x => x.SerialNo == requestId && x.ChargeBoxId == session.ChargeBoxId && x.Status == 0)
  147. .FirstOrDefaultAsync();
  148. if (operation != null)
  149. {
  150. operation.FinishedOn = DateTime.UtcNow;
  151. operation.Status = 1;//電樁有回覆
  152. operation.EVSE_Value = string.IsNullOrEmpty(evse_rep) ? operation.EVSE_Value : evse_rep;
  153. await db.SaveChangesAsync();
  154. }
  155. }
  156. }
  157. break;
  158. default:
  159. {
  160. logger.LogWarning(string.Format("Not Implement {0} Logic", confirm.GetType().ToString().Replace("OCPPPackage.Messages.FirmwareManagement.", "")));
  161. }
  162. break;
  163. }
  164. return result;
  165. }
  166. internal async Task<MessageResult> ReceivedFirmwareManagementError(Actions action, string errorMsg, WsClientData session, string requestId)
  167. {
  168. MessageResult result = new MessageResult() { Success = true };
  169. switch (action)
  170. {
  171. case Actions.FirmwareStatusNotification:
  172. case Actions.UpdateFirmware:
  173. case Actions.GetDiagnostics:
  174. case Actions.DiagnosticsStatusNotification:
  175. {
  176. using (var db = await maindbContextFactory.CreateDbContextAsync())
  177. {
  178. var operation = await db.MachineOperateRecord
  179. .Where(x => x.SerialNo == requestId && x.ChargeBoxId == session.ChargeBoxId && x.Status == 0)
  180. .FirstOrDefaultAsync();
  181. if (operation != null)
  182. {
  183. operation.FinishedOn = DateTime.UtcNow;
  184. operation.Status = 1;//電樁有回覆
  185. operation.EVSE_Status = (int)255;//錯誤
  186. operation.EVSE_Value = errorMsg;
  187. await db.SaveChangesAsync();
  188. }
  189. }
  190. }
  191. break;
  192. default:
  193. {
  194. logger.LogWarning(string.Format("Not Implement {0} Logic", action));
  195. }
  196. break;
  197. }
  198. return result;
  199. }
  200. }
  201. }