BasicMessageHandler.cs 6.3 KB

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