BasicMessageHandler.cs 6.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158
  1. using EVCB_OCPP.Packet.Features;
  2. using EVCB_OCPP.Packet.Messages;
  3. using EVCB_OCPP.WSServer.Service.WsService;
  4. using Microsoft.Extensions.Logging;
  5. using Newtonsoft.Json;
  6. using Newtonsoft.Json.Serialization;
  7. using NLog;
  8. namespace EVCB_OCPP.WSServer.Message
  9. {
  10. /// <summary>
  11. /// 實現 OCPP 基本傳送規範,
  12. /// 1.訊息 基本格式,將訊息包裝成 Call 、CallResult、CallError 三種格式
  13. /// 2.OCPP 定義的傳送規則:交易相關的訊息必須依照時序性傳送,一個傳完才能接著送下一個(忽略規則 由Center System定義)
  14. /// </summary>
  15. internal class BasicMessageHandler
  16. {
  17. static internal Logger logger = NLog.LogManager.GetCurrentClassLogger();
  18. #region 傳送 or 解析訊息需要欄位
  19. private const int INDEX_MESSAGEID = 0;
  20. private const int INDEX_UNIQUEID = 1;
  21. internal const int TYPENUMBER_CALL = 2;
  22. private const int INDEX_CALL_ACTION = 2;
  23. private const int INDEX_CALL_PAYLOAD = 3;
  24. internal const int TYPENUMBER_CALLRESULT = 3;
  25. private const int INDEX_CALLRESULT_PAYLOAD = 2;
  26. internal const int TYPENUMBER_CALLERROR = 4;
  27. private const int INDEX_CALLERROR_ERRORCODE = 2;
  28. private const int INDEX_CALLERROR_DESCRIPTION = 3;
  29. private const int INDEX_CALLERROR_PAYLOAD = 4;
  30. private const string CALL_FORMAT = "[2,\"{0}\",\"{1}\",{2}]";
  31. private const string CALLRESULT_FORMAT = "[3,\"{0}\",{1}]";
  32. private const string CALLERROR_FORMAT = "[4,\"{0}\",\"{1}\",\"{2}\",{3}]";
  33. private const string DATE_FORMAT = "yyyy-MM-dd'T'HH:mm:ss'Z'";
  34. private const string DATE_FORMAT_WITH_MS = "yyyy-MM-dd'T'HH:mm:ss.SSS'Z'";
  35. #endregion
  36. private OCPP16MessageHandler _ocpp16Handler = new OCPP16MessageHandler();
  37. private OCPP20MessageHandler _ocpp20Handler = new OCPP20MessageHandler();
  38. /// <summary>
  39. /// 將收到的封包做基本的拆解分成 Call 、CallResult、CallError
  40. /// </summary>
  41. /// <param name="client"></param>
  42. /// <param name="data"></param>
  43. /// <returns></returns>
  44. internal MessageResult AnalysisReceiveData(WsClientData client, string data)
  45. {
  46. MessageResult result = null;
  47. if (!client.ISOCPP20)
  48. {
  49. result = _ocpp16Handler.AnalysisReceiveData(client, data);
  50. }
  51. else
  52. {
  53. result = _ocpp20Handler.AnalysisReceiveData(client, data);
  54. }
  55. return result;
  56. }
  57. static internal string GenerateCallError(string uniqueId, string errorCode, string errorDescription)
  58. {
  59. string msg = string.Format(CALLERROR_FORMAT, uniqueId, errorCode, errorDescription, "{}");
  60. return msg;
  61. }
  62. static internal string GenerateConfirmation(string uniqueId, IConfirmation confirmation)
  63. {
  64. string msg = string.Empty;
  65. if (confirmation != null && confirmation.Validate())
  66. {
  67. msg = string.Format(CALLRESULT_FORMAT, uniqueId, JsonConvert.SerializeObject(confirmation, new JsonSerializerSettings() { ContractResolver = new CamelCasePropertyNamesContractResolver(), NullValueHandling = NullValueHandling.Ignore, Formatting = Formatting.None }));
  68. }
  69. else
  70. {
  71. logger.Error(string.Format("confirmation is null or InVaild in GenerateConfirmation Method"), "Warning");
  72. }
  73. return msg;
  74. }
  75. static internal string GenerateConfirmationofOCPP20(string uniqueId, EVCB_OCPP20.Packet.Messages.IConfirmation confirmation)
  76. {
  77. string msg = string.Empty;
  78. if (confirmation != null && confirmation.Validate())
  79. {
  80. msg = string.Format(CALLRESULT_FORMAT, uniqueId, JsonConvert.SerializeObject(confirmation, new JsonSerializerSettings() { ContractResolver = new CamelCasePropertyNamesContractResolver(), NullValueHandling = NullValueHandling.Ignore, Formatting = Formatting.None }));
  81. }
  82. else
  83. {
  84. logger.Error(string.Format("confirmation is null or InVaild in GenerateConfirmation Method"), "Warning");
  85. }
  86. return msg;
  87. }
  88. static internal string GenerateRequest(string uniqueId, string action, IRequest request)
  89. {
  90. string msg = string.Empty;
  91. if (request != null && request.Validate())
  92. {
  93. msg = string.Format(CALL_FORMAT, uniqueId, action, JsonConvert.SerializeObject(request, new JsonSerializerSettings() { ContractResolver = new CamelCasePropertyNamesContractResolver(), NullValueHandling = NullValueHandling.Ignore, Formatting = Formatting.None }));
  94. }
  95. else
  96. {
  97. if (action == Actions.ChangeConfiguration.ToString())
  98. {
  99. if(!request.Validate())
  100. {
  101. logger.Error("!Validate", "Warning");
  102. }
  103. if (request == null)
  104. {
  105. logger.Error("!NULL", "Warning");
  106. }
  107. }
  108. logger.Error(string.Format("confirmation is null or InVaild in GenerateRequest Method "+ action), "Warning");
  109. }
  110. return msg;
  111. }
  112. static internal string GenerateRequestofOCPP20(string uniqueId, string action, EVCB_OCPP20.Packet.Messages.IRequest request)
  113. {
  114. string msg = string.Empty;
  115. if (request != null && request.Validate())
  116. {
  117. msg = string.Format(CALL_FORMAT, uniqueId, action, JsonConvert.SerializeObject(request, new JsonSerializerSettings() { ContractResolver = new CamelCasePropertyNamesContractResolver(), NullValueHandling = NullValueHandling.Ignore, Formatting = Formatting.None }));
  118. }
  119. else
  120. {
  121. logger.Error(string.Format("confirmation is null or InVaild in GenerateRequest Method"), "Warning");
  122. }
  123. return msg;
  124. }
  125. static internal string GenerateDestroyRequest(string uniqueId, string action, string request)
  126. {
  127. return string.Format(CALL_FORMAT, uniqueId, action, request);
  128. }
  129. }
  130. }