CPOController.cs 83 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858
  1. using EVCB_OCPP.WEBAPI.Handlers;
  2. using EVCB_OCPP.WEBAPI.Models.WebAPI;
  3. using EVCB_OCPP.WEBAPI.Services;
  4. using System;
  5. using System.Collections.Generic;
  6. using System.Linq;
  7. using System.Net;
  8. using System.Net.Http;
  9. using System.Web.Http;
  10. using System.Web.Http.Description;
  11. using Newtonsoft.Json;
  12. using System.Threading.Tasks;
  13. using EVCB_OCPP.WEBAPI.Models.WebAPI.Dto;
  14. using System.Net.Http.Headers;
  15. using EVCB_OCPP.Packet.Messages.SubTypes;
  16. using System.Security.Cryptography.X509Certificates;
  17. using OCPPPackage.Profiles;
  18. using EVCB_OCPP.Packet.Messages.Core;
  19. using EVCB_OCPP.Packet.Messages;
  20. namespace EVCB_OCPP.WEBAPI.Controllers.Version1
  21. {
  22. [ApiExplorerSettings(IgnoreApi = true)]
  23. [RoutePrefix("api/v1/cpo")]
  24. [CPOAuthentication]
  25. public class CPOController : ApiController
  26. {
  27. private HttpClientService service = new HttpClientService();
  28. private bool ContainsChargePoint(string chargeBoxId, out string customerId)
  29. {
  30. customerId = string.Empty;
  31. if (!Request.Headers.Contains(EVCBConfiguration.Header_PartnerId)) return false;
  32. customerId = Request.Headers.GetValues(EVCBConfiguration.Header_PartnerId).First();
  33. ChargePointService _service = new ChargePointService();
  34. return _service.ContainsChargePoint(chargeBoxId, customerId);
  35. }
  36. [Route("station")]
  37. [ResponseType(typeof(CPOOuterResponse))]
  38. [HttpGet]
  39. public HttpResponseMessage Station()
  40. {
  41. var result = new CPOOuterResponse();
  42. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  43. try
  44. {
  45. if (Request.Headers.Contains(EVCBConfiguration.Header_PartnerId))
  46. {
  47. var _customerId = Request.Headers.GetValues(EVCBConfiguration.Header_PartnerId).First();
  48. ChargingStationService _service = new ChargingStationService();
  49. var _innerResponse = new { Stations = _service.GetStationsbyCustomerId(_customerId) };
  50. result.Data = JsonConvert.SerializeObject(_innerResponse, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  51. result.StatusCode = (int)CPO_StatusCode.Success;
  52. result.StatusMessage = CPO_StatusMessage.Success;
  53. statusCode = HttpStatusCode.OK;
  54. }
  55. return Request.CreateResponse(statusCode, result);
  56. }
  57. catch (Exception ex)
  58. {
  59. result.ErrorDetail = ex.ToString();
  60. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  61. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  62. return Request.CreateResponse(statusCode, result);
  63. }
  64. }
  65. [Route("information")]
  66. [ResponseType(typeof(CPOOuterResponse))]
  67. [HttpGet]
  68. public HttpResponseMessage BasicInformationofEVSEs(int? Limit = -1, int StationId = -1, string ChargeBoxId = "", DateTime? DateFrom = null, DateTime? DateTo = null, int? Offset = 0)
  69. {
  70. var result = new CPOOuterResponse();
  71. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  72. try
  73. {
  74. ChargePointService _CPService = new ChargePointService();
  75. var tt = _CPService.GetLastUpdatedTimebyMachineId("0da4f4a6-a952-46f0-b2f3-696385a9a56a");
  76. if (Request.Headers.Contains(EVCBConfiguration.Header_PartnerId))
  77. {
  78. var _customerId = Request.Headers.GetValues(EVCBConfiguration.Header_PartnerId).First();
  79. var _innerResponse = new { EVSEs = new List<EVSE>() };
  80. ChargingStationService _stationService = new ChargingStationService();
  81. if (StationId > -1)
  82. {
  83. if (_stationService.ContainsStation(_customerId, StationId))
  84. {
  85. if (DateTo.HasValue)
  86. {
  87. if (!DateFrom.HasValue)
  88. {
  89. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_PARAMETER_OUTOFRANGE_INCORRECT;
  90. result.StatusCode = (int)CPO_StatusCode.PARAMETER_OUTOFRANGE_INCORRECT;
  91. statusCode = HttpStatusCode.BadRequest;
  92. return Request.CreateResponse(statusCode, result);
  93. }
  94. }
  95. _innerResponse = new { EVSEs = _stationService.GetEVSEsbyStationId(StationId, DateFrom, DateTo, Offset.Value, Limit == -1 ? 1000 : Limit.Value) };
  96. }
  97. }
  98. else
  99. {
  100. _innerResponse = new { EVSEs = new List<EVSE>() };
  101. _innerResponse.EVSEs.Add(_CPService.GetEVSEsbyChargeBoxId(ChargeBoxId, DateFrom, DateTo));
  102. }
  103. result.Data = JsonConvert.SerializeObject(_innerResponse, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  104. result.StatusCode = (int)CPO_StatusCode.Success;
  105. result.StatusMessage = CPO_StatusMessage.Success;
  106. statusCode = HttpStatusCode.OK;
  107. }
  108. return Request.CreateResponse(statusCode, result);
  109. }
  110. catch (Exception ex)
  111. {
  112. result.ErrorDetail = ex.ToString();
  113. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  114. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  115. return Request.CreateResponse(statusCode, result);
  116. }
  117. }
  118. [Route("commands/start_session")]
  119. [ResponseType(typeof(CPOOuterResponse))]
  120. [HttpPost]
  121. async public Task<HttpResponseMessage> StartSession([FromBody] StartSessionRequest request)
  122. {
  123. var result = new CPOOuterResponse();
  124. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  125. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  126. try
  127. {
  128. string _CustomerId = string.Empty;
  129. if (!ContainsChargePoint(request.ChargeBoxId, out _CustomerId))
  130. {
  131. // 沒槍~ 沒得充...
  132. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_DOESNT_EXIST;
  133. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  134. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  135. statusCode = HttpStatusCode.BadRequest;
  136. return Request.CreateResponse(statusCode, result);
  137. }
  138. ChargePointService _CPService = new ChargePointService();
  139. if (!string.IsNullOrEmpty(request.ChargeBoxId) && request.ChargeBoxId.Length <= 25 && (!request.ConnectorId.HasValue
  140. || (_CPService.GetNumberofConnectors(request.ChargeBoxId) >= request.ConnectorId && request.ConnectorId > 0))
  141. && !string.IsNullOrEmpty(request.Token) && request.Token.Length <= 20)
  142. {
  143. InternalHttpClient _client = new InternalHttpClient();
  144. CustomerService _customer = new CustomerService();
  145. //trigger to charge
  146. var _request = new Models.WebAPI.StartTransactionRequest()
  147. {
  148. ConnectorId = request.ConnectorId,
  149. IdTag = request.Token
  150. };
  151. string[] parts = Request.RequestUri.ToString().Split('/');
  152. string urlformat = "{0}//{1}/api/v1/ocpp16/transaction?ChargeBoxId={3}";
  153. var _innerResult = await _client.Post(string.Format(urlformat, parts[0], parts[2], Request.RequestUri.Port, request.ChargeBoxId), new Dictionary<string, string>()
  154. {
  155. { "PartnerId",_CustomerId}
  156. }, _request, _customer.GetAPIKey(new Guid(_CustomerId)));
  157. _innerData = new { Result = string.IsNullOrEmpty(_innerResult.SerialNo) ? CommandResponseType.Rejected.ToString() : CommandResponseType.Accepted.ToString(), Timeout = 60 };
  158. result = GetErrorDescription(_innerResult);
  159. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  160. if (_innerResult.Status == HttpStatusCode.InternalServerError)
  161. {
  162. result.StatusCode = _innerResult.ErrorCode;
  163. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_INNERSERVICE_ERROR;
  164. statusCode = HttpStatusCode.InternalServerError;
  165. }
  166. else
  167. {
  168. result.SerialNo = _innerResult.SerialNo;
  169. result.StatusCode = _innerResult.ErrorCode;
  170. result.StatusMessage = _innerResult.Message;
  171. statusCode = HttpStatusCode.OK;
  172. }
  173. }
  174. else
  175. {
  176. // 參數不符合定義
  177. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_PARAMETER_OUTOFRANGE_INCORRECT;
  178. result.StatusCode = (int)CPO_StatusCode.PARAMETER_OUTOFRANGE_INCORRECT;
  179. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  180. statusCode = HttpStatusCode.BadRequest;
  181. }
  182. return Request.CreateResponse(statusCode, result);
  183. }
  184. catch (Exception ex)
  185. {
  186. result.ErrorDetail = ex.ToString();
  187. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  188. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  189. return Request.CreateResponse(statusCode, result);
  190. }
  191. }
  192. [Route("commands/stop_session")]
  193. [ResponseType(typeof(CPOOuterResponse))]
  194. [HttpPost]
  195. async public Task<HttpResponseMessage> StopSession(string ChargeBoxId, int SessionId)
  196. {
  197. var result = new CPOOuterResponse();
  198. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  199. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  200. try
  201. {
  202. string _CustomerId = string.Empty;
  203. if (!ContainsChargePoint(ChargeBoxId, out _CustomerId))
  204. {
  205. // 沒槍~ 沒得充...
  206. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_DOESNT_EXIST;
  207. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  208. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  209. statusCode = HttpStatusCode.BadRequest;
  210. return Request.CreateResponse(statusCode, result);
  211. }
  212. InternalHttpClient _client = new InternalHttpClient();
  213. CustomerService _customer = new CustomerService();
  214. string[] parts = Request.RequestUri.ToString().Split('/');
  215. string urlformat = "{0}//{1}/api/v1/ocpp16/transaction?ChargeBoxId={2}&TransactionId={3}";
  216. var _innerResult = await _client.Put(string.Format(urlformat, parts[0], parts[2], ChargeBoxId, SessionId), new Dictionary<string, string>()
  217. {
  218. { "PartnerId",_CustomerId}
  219. }, null, _customer.GetAPIKey(new Guid(_CustomerId)));
  220. _innerData = new { Result = string.IsNullOrEmpty(_innerResult.SerialNo) ? CommandResponseType.Rejected.ToString() : CommandResponseType.Accepted.ToString(), Timeout = 60 };
  221. result = GetErrorDescription(_innerResult);
  222. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  223. if (_innerResult.Success)
  224. {
  225. result.SerialNo = _innerResult.SerialNo;
  226. result.StatusCode = (int)CPO_StatusCode.Success;
  227. result.StatusMessage = CPO_StatusMessage.Success;
  228. statusCode = HttpStatusCode.OK;
  229. }
  230. else
  231. {
  232. if (_innerResult.ErrorCode == (int)CPO_StatusCode.UnexpectedError)
  233. {
  234. result.StatusCode = _innerResult.ErrorCode;
  235. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_INNERSERVICE_ERROR;
  236. statusCode = HttpStatusCode.BadRequest;
  237. }
  238. else
  239. {
  240. result.StatusCode = (int)CPO_StatusCode.Success;
  241. result.StatusMessage = CPO_StatusMessage.Success;
  242. statusCode = HttpStatusCode.OK;
  243. }
  244. }
  245. }
  246. catch (Exception ex)
  247. {
  248. result.ErrorDetail = ex.ToString();
  249. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  250. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  251. return Request.CreateResponse(statusCode, result);
  252. }
  253. return Request.CreateResponse(statusCode, result);
  254. }
  255. [Route("commands/reserve_now")]
  256. [ResponseType(typeof(CPOOuterResponse))]
  257. [HttpPost]
  258. async public Task<HttpResponseMessage> ReserveNow([FromBody] ReserveNowRequest request)
  259. {
  260. var result = new CPOOuterResponse();
  261. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  262. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  263. try
  264. {
  265. string _CustomerId = string.Empty;
  266. if (!ContainsChargePoint(request.ChargeBoxId, out _CustomerId))
  267. {
  268. // 沒槍~ 沒得充...
  269. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_DOESNT_EXIST;
  270. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  271. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  272. statusCode = HttpStatusCode.BadRequest;
  273. return Request.CreateResponse(statusCode, result);
  274. }
  275. InternalHttpClient _client = new InternalHttpClient();
  276. CustomerService _customer = new CustomerService();
  277. string[] parts = Request.RequestUri.ToString().Split('/');
  278. string urlformat = "{0}//{1}/api/v1/ocpp16/reservation?ChargeBoxId={2}";
  279. var _innerRequest = new ReserveRequest()
  280. {
  281. ConnectorId = request.ConnectorId,
  282. IdTag = request.Token,
  283. ReservationId = request.ReservationId,
  284. ExpiryDate = request.ExpiryDate.ToString(EVCBConfiguration.UTC_DATETIMEFORMAT)
  285. };
  286. var _innerResult = await _client.Post(string.Format(urlformat, parts[0], parts[2], request.ChargeBoxId), new Dictionary<string, string>()
  287. {
  288. { "PartnerId",_CustomerId}
  289. }, _innerRequest, _customer.GetAPIKey(new Guid(_CustomerId)));
  290. _innerData = new { Result = string.IsNullOrEmpty(_innerResult.SerialNo) ? CommandResponseType.Rejected.ToString() : CommandResponseType.Accepted.ToString(), Timeout = 60 };
  291. result = GetErrorDescription(_innerResult);
  292. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  293. if (_innerResult.Success)
  294. {
  295. result.SerialNo = _innerResult.SerialNo;
  296. result.StatusCode = (int)CPO_StatusCode.Success;
  297. result.StatusMessage = CPO_StatusMessage.Success;
  298. statusCode = HttpStatusCode.OK;
  299. }
  300. else
  301. {
  302. result.StatusCode = _innerResult.ErrorCode;
  303. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_INNERSERVICE_ERROR;
  304. statusCode = HttpStatusCode.BadRequest;
  305. }
  306. }
  307. catch (Exception ex)
  308. {
  309. result.ErrorDetail = ex.ToString();
  310. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  311. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  312. return Request.CreateResponse(statusCode, result);
  313. }
  314. return Request.CreateResponse(statusCode, result);
  315. }
  316. [Route("commands/cancel_reservation")]
  317. [ResponseType(typeof(CPOOuterResponse))]
  318. [HttpPost]
  319. async public Task<HttpResponseMessage> CancelReservation(string ChargeBoxId, int ReservationId)
  320. {
  321. var result = new CPOOuterResponse();
  322. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  323. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  324. try
  325. {
  326. string _CustomerId = string.Empty;
  327. if (!ContainsChargePoint(ChargeBoxId, out _CustomerId))
  328. {
  329. // 沒槍~ 沒得充...
  330. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_DOESNT_EXIST;
  331. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  332. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  333. statusCode = HttpStatusCode.BadRequest;
  334. return Request.CreateResponse(statusCode, result);
  335. }
  336. InternalHttpClient _client = new InternalHttpClient();
  337. CustomerService _customer = new CustomerService();
  338. string[] parts = Request.RequestUri.ToString().Split('/');
  339. string urlformat = "{0}//{1}/api/v1/ocpp16/reservation?ChargeBoxId={2}&ReservationId={3}";
  340. var _innerResult = await _client.Delete(string.Format(urlformat, parts[0], parts[2], ChargeBoxId, ReservationId), new Dictionary<string, string>()
  341. {
  342. { "PartnerId",_CustomerId}
  343. }, _customer.GetAPIKey(new Guid(_CustomerId)));
  344. _innerData = new { Result = string.IsNullOrEmpty(_innerResult.SerialNo) ? CommandResponseType.Rejected.ToString() : CommandResponseType.Accepted.ToString(), Timeout = 60 };
  345. result = GetErrorDescription(_innerResult);
  346. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  347. if (_innerResult.Success)
  348. {
  349. result.SerialNo = _innerResult.SerialNo;
  350. result.StatusCode = (int)CPO_StatusCode.Success;
  351. result.StatusMessage = CPO_StatusMessage.Success;
  352. statusCode = HttpStatusCode.OK;
  353. }
  354. else
  355. {
  356. if (_innerResult.ErrorCode == (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE)
  357. {
  358. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  359. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  360. statusCode = HttpStatusCode.OK;
  361. }
  362. else
  363. {
  364. result.StatusCode = _innerResult.ErrorCode;
  365. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_INNERSERVICE_ERROR;
  366. statusCode = HttpStatusCode.BadRequest;
  367. }
  368. }
  369. }
  370. catch (Exception ex)
  371. {
  372. result.ErrorDetail = ex.ToString();
  373. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  374. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  375. return Request.CreateResponse(statusCode, result);
  376. }
  377. return Request.CreateResponse(statusCode, result);
  378. }
  379. [Route("commands/chargingprofiles")]
  380. [ResponseType(typeof(CPOOuterResponse))]
  381. [HttpGet]
  382. async public Task<HttpResponseMessage> GetActiveChargingProfile(string ChargeBoxId, int ConnectorId, int Duration)
  383. {
  384. var result = new CPOOuterResponse();
  385. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  386. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  387. try
  388. {
  389. string _CustomerId = string.Empty;
  390. if (!ContainsChargePoint(ChargeBoxId, out _CustomerId))
  391. {
  392. // 沒槍~ 沒得充...
  393. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  394. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  395. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  396. statusCode = HttpStatusCode.BadRequest;
  397. return Request.CreateResponse(statusCode, result);
  398. }
  399. InternalHttpClient _client = new InternalHttpClient();
  400. CustomerService _customer = new CustomerService();
  401. string[] parts = Request.RequestUri.ToString().Split('/');
  402. string urlformat = "{0}//{1}/api/v1/ocpp16/compositeschedule?ChargeBoxId={2}&ConnectorId={3}&Duration={4}";
  403. var _innerResult = await _client.Get(string.Format(urlformat, parts[0], parts[2], ChargeBoxId, ConnectorId, Duration), new Dictionary<string, string>()
  404. {
  405. { "PartnerId",_CustomerId}
  406. }, _customer.GetAPIKey(new Guid(_CustomerId)));
  407. _innerData = new { Result = string.IsNullOrEmpty(_innerResult.SerialNo) ? CommandResponseType.Rejected.ToString() : CommandResponseType.Accepted.ToString(), Timeout = 60 };
  408. result = GetErrorDescription(_innerResult);
  409. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  410. if (_innerResult.Success)
  411. {
  412. result.SerialNo = _innerResult.SerialNo;
  413. result.StatusCode = (int)CPO_StatusCode.Success;
  414. result.StatusMessage = CPO_StatusMessage.Success;
  415. statusCode = HttpStatusCode.OK;
  416. }
  417. else
  418. {
  419. if (_innerResult.ErrorCode == (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE)
  420. {
  421. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  422. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  423. statusCode = HttpStatusCode.OK;
  424. }
  425. else
  426. {
  427. result.StatusCode = _innerResult.ErrorCode;
  428. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_INNERSERVICE_ERROR;
  429. statusCode = HttpStatusCode.BadRequest;
  430. }
  431. }
  432. }
  433. catch (Exception ex)
  434. {
  435. result.ErrorDetail = ex.ToString();
  436. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  437. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  438. return Request.CreateResponse(statusCode, result);
  439. }
  440. return Request.CreateResponse(statusCode, result);
  441. }
  442. [Route("commands/chargingporfiles")]
  443. [ResponseType(typeof(CPOOuterResponse))]
  444. [HttpPut]
  445. async public Task<HttpResponseMessage> SetChargingProfile(string ChargeBoxId, [FromBody] ChargingProfileRequest request)
  446. {
  447. var result = new CPOOuterResponse();
  448. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  449. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  450. try
  451. {
  452. string _CustomerId = string.Empty;
  453. if (!ContainsChargePoint(ChargeBoxId, out _CustomerId))
  454. {
  455. // 沒槍~ 沒得充...
  456. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_DOESNT_EXIST;
  457. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  458. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  459. statusCode = HttpStatusCode.BadRequest;
  460. return Request.CreateResponse(statusCode, result);
  461. }
  462. InternalHttpClient _client = new InternalHttpClient();
  463. CustomerService _customer = new CustomerService();
  464. string[] parts = Request.RequestUri.ToString().Split('/');
  465. string urlformat = "{0}//{1}/api/v1/ocpp16/chargingprofile?ChargeBoxId={2}";
  466. var _innerResult = await _client.Post(string.Format(urlformat, parts[0], parts[2], ChargeBoxId), new Dictionary<string, string>()
  467. {
  468. { "PartnerId",_CustomerId}
  469. }, request, _customer.GetAPIKey(new Guid(_CustomerId)));
  470. _innerData = new { Result = string.IsNullOrEmpty(_innerResult.SerialNo) ? CommandResponseType.Rejected.ToString() : CommandResponseType.Accepted.ToString(), Timeout = 60 };
  471. result = GetErrorDescription(_innerResult);
  472. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  473. if (_innerResult.Success)
  474. {
  475. result.SerialNo = _innerResult.SerialNo;
  476. result.StatusCode = (int)CPO_StatusCode.Success;
  477. result.StatusMessage = CPO_StatusMessage.Success;
  478. statusCode = HttpStatusCode.OK;
  479. }
  480. else
  481. {
  482. if (_innerResult.ErrorCode == (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE)
  483. {
  484. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  485. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  486. statusCode = HttpStatusCode.OK;
  487. }
  488. else
  489. {
  490. result.StatusCode = _innerResult.ErrorCode;
  491. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_INNERSERVICE_ERROR;
  492. statusCode = HttpStatusCode.BadRequest;
  493. }
  494. }
  495. ChargePointService chargePointService = new ChargePointService();
  496. if (!chargePointService.IsOnline(ChargeBoxId))
  497. {
  498. return Request.CreateResponse(HttpStatusCode.BadRequest, new ErrorResponse() { Code = 2101, Message = EVCBConfiguration.ERROR_MSG_CHARGEBOXID_ISNT_EXIST_OR_OFFLINE });
  499. }
  500. }
  501. catch (Exception ex)
  502. {
  503. result.ErrorDetail = ex.ToString();
  504. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  505. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  506. return Request.CreateResponse(statusCode, result);
  507. }
  508. return Request.CreateResponse(statusCode, result);
  509. }
  510. [Route("commands/chargingporfiles")]
  511. [ResponseType(typeof(CPOOuterResponse))]
  512. [HttpDelete]
  513. async public Task<HttpResponseMessage> ClearChargingPorfile(string ChargeBoxId, int ChargeProfileId = -1)
  514. {
  515. var result = new CPOOuterResponse();
  516. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  517. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  518. try
  519. {
  520. string _CustomerId = string.Empty;
  521. if (!ContainsChargePoint(ChargeBoxId, out _CustomerId))
  522. {
  523. // 沒槍~ 沒得充...
  524. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_DOESNT_EXIST;
  525. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  526. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  527. statusCode = HttpStatusCode.BadRequest;
  528. return Request.CreateResponse(statusCode, result);
  529. }
  530. InternalHttpClient _client = new InternalHttpClient();
  531. CustomerService _customer = new CustomerService();
  532. string[] parts = Request.RequestUri.ToString().Split('/');
  533. string urlformat = "{0}//{1}/api/v1/ocpp16/chargingprofile?ChargeBoxId={2}{3}";
  534. var _innerResult = await _client.Delete(string.Format(urlformat, parts[0], parts[2], ChargeBoxId, ChargeProfileId == -1 ? "" : "&Id=" + ChargeProfileId), new Dictionary<string, string>()
  535. {
  536. { "PartnerId",_CustomerId}
  537. }, _customer.GetAPIKey(new Guid(_CustomerId)));
  538. _innerData = new { Result = string.IsNullOrEmpty(_innerResult.SerialNo) ? CommandResponseType.Rejected.ToString() : CommandResponseType.Accepted.ToString(), Timeout = 60 };
  539. result = GetErrorDescription(_innerResult);
  540. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  541. if (_innerResult.Success)
  542. {
  543. result.SerialNo = _innerResult.SerialNo;
  544. result.StatusCode = (int)CPO_StatusCode.Success;
  545. result.StatusMessage = CPO_StatusMessage.Success;
  546. statusCode = HttpStatusCode.OK;
  547. }
  548. else
  549. {
  550. if (_innerResult.ErrorCode == (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE)
  551. {
  552. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  553. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  554. statusCode = HttpStatusCode.OK;
  555. }
  556. else
  557. {
  558. result.StatusCode = _innerResult.ErrorCode;
  559. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_INNERSERVICE_ERROR;
  560. statusCode = HttpStatusCode.BadRequest;
  561. }
  562. }
  563. }
  564. catch (Exception ex)
  565. {
  566. result.ErrorDetail = ex.ToString();
  567. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  568. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  569. return Request.CreateResponse(statusCode, result);
  570. }
  571. return Request.CreateResponse(statusCode, result);
  572. }
  573. [Route("commands/set_locallist")]
  574. [ResponseType(typeof(CPOOuterResponse))]
  575. [HttpPost]
  576. async public Task<HttpResponseMessage> SendLocalList(string ChargeBoxId, [FromBody] LocalListRequest request)
  577. {
  578. var result = new CPOOuterResponse();
  579. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  580. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  581. try
  582. {
  583. string _CustomerId = string.Empty;
  584. if (!ContainsChargePoint(ChargeBoxId, out _CustomerId))
  585. {
  586. // 沒槍~ 沒得充...
  587. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_DOESNT_EXIST;
  588. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  589. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  590. statusCode = HttpStatusCode.BadRequest;
  591. return Request.CreateResponse(statusCode, result);
  592. }
  593. InternalHttpClient _client = new InternalHttpClient();
  594. CustomerService _customer = new CustomerService();
  595. string[] parts = Request.RequestUri.ToString().Split('/');
  596. string urlformat = "{0}//{1}/api/v1/ocpp16/locallist?ChargeBoxId={2}";
  597. var _innerResult = await _client.Post(string.Format(urlformat, parts[0], parts[2], ChargeBoxId), new Dictionary<string, string>()
  598. {
  599. { "PartnerId",_CustomerId}
  600. }, request, _customer.GetAPIKey(new Guid(_CustomerId)));
  601. _innerData = new { Result = string.IsNullOrEmpty(_innerResult.SerialNo) ? CommandResponseType.Rejected.ToString() : CommandResponseType.Accepted.ToString(), Timeout = 60 };
  602. result = GetErrorDescription(_innerResult);
  603. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  604. if (_innerResult.Success)
  605. {
  606. result.SerialNo = _innerResult.SerialNo;
  607. result.StatusCode = (int)CPO_StatusCode.Success;
  608. result.StatusMessage = CPO_StatusMessage.Success;
  609. statusCode = HttpStatusCode.OK;
  610. }
  611. else
  612. {
  613. if (_innerResult.ErrorCode == (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE)
  614. {
  615. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  616. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  617. statusCode = HttpStatusCode.OK;
  618. }
  619. else
  620. {
  621. result.StatusCode = _innerResult.ErrorCode;
  622. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_INNERSERVICE_ERROR;
  623. statusCode = HttpStatusCode.BadRequest;
  624. }
  625. }
  626. }
  627. catch (Exception ex)
  628. {
  629. result.ErrorDetail = ex.ToString();
  630. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  631. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  632. return Request.CreateResponse(statusCode, result);
  633. }
  634. return Request.CreateResponse(statusCode, result);
  635. }
  636. [Route("commands/locallistversion")]
  637. [ResponseType(typeof(CPOOuterResponse))]
  638. [HttpGet]
  639. async public Task<HttpResponseMessage> GetLocalListVersion(string ChargeBoxId)
  640. {
  641. var result = new CPOOuterResponse();
  642. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  643. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  644. try
  645. {
  646. string _CustomerId = string.Empty;
  647. if (!ContainsChargePoint(ChargeBoxId, out _CustomerId))
  648. {
  649. // 沒槍~ 沒得充...
  650. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_DOESNT_EXIST;
  651. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  652. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  653. statusCode = HttpStatusCode.BadRequest;
  654. return Request.CreateResponse(statusCode, result);
  655. }
  656. InternalHttpClient _client = new InternalHttpClient();
  657. CustomerService _customer = new CustomerService();
  658. string[] parts = Request.RequestUri.ToString().Split('/');
  659. string urlformat = "{0}//{1}/api/v1/ocpp16/locallistversion?ChargeBoxId={2}";
  660. var _innerResult = await _client.Get(string.Format(urlformat, parts[0], parts[2], ChargeBoxId), new Dictionary<string, string>()
  661. {
  662. { "PartnerId",_CustomerId}
  663. }, _customer.GetAPIKey(new Guid(_CustomerId)));
  664. _innerData = new { Result = string.IsNullOrEmpty(_innerResult.SerialNo) ? CommandResponseType.Rejected.ToString() : CommandResponseType.Accepted.ToString(), Timeout = 60 };
  665. result = GetErrorDescription(_innerResult);
  666. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  667. if (_innerResult.Success)
  668. {
  669. result.SerialNo = _innerResult.SerialNo;
  670. result.StatusCode = (int)CPO_StatusCode.Success;
  671. result.StatusMessage = CPO_StatusMessage.Success;
  672. statusCode = HttpStatusCode.OK;
  673. }
  674. else
  675. {
  676. if (_innerResult.ErrorCode == (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE)
  677. {
  678. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  679. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  680. statusCode = HttpStatusCode.OK;
  681. }
  682. else
  683. {
  684. result.StatusCode = _innerResult.ErrorCode;
  685. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_INNERSERVICE_ERROR;
  686. statusCode = HttpStatusCode.BadRequest;
  687. }
  688. }
  689. statusCode = HttpStatusCode.OK;
  690. }
  691. catch (Exception ex)
  692. {
  693. result.ErrorDetail = ex.ToString();
  694. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  695. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  696. return Request.CreateResponse(statusCode, result);
  697. }
  698. return Request.CreateResponse(statusCode, result);
  699. }
  700. [Route("commands/results")]
  701. [ResponseType(typeof(CPOOuterResponse))]
  702. [HttpGet]
  703. async public Task<HttpResponseMessage> ExecutionofCmdSearch(string ChargeBoxId, CommandType? commandType, string SerialNo)
  704. {
  705. var result = new CPOOuterResponse();
  706. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  707. try
  708. {
  709. string _CustomerId = string.Empty;
  710. if (!ContainsChargePoint(ChargeBoxId, out _CustomerId))
  711. {
  712. // 沒槍~ 沒得充...
  713. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_DOESNT_EXIST;
  714. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  715. statusCode = HttpStatusCode.BadRequest;
  716. return Request.CreateResponse(statusCode, result);
  717. }
  718. InternalHttpClient _client = new InternalHttpClient();
  719. CustomerService _customer = new CustomerService();
  720. int? orderNo = (int?)null;
  721. switch (commandType.Value)
  722. {
  723. case CommandType.CancelReservation:
  724. {
  725. orderNo = 4;
  726. }
  727. break;
  728. case CommandType.ClearChargingProfile:
  729. {
  730. orderNo = 6;
  731. }
  732. break;
  733. case CommandType.GetAcitveChargingProfile:
  734. {
  735. orderNo = 7;
  736. }
  737. break;
  738. case CommandType.GetLocalListVersion:
  739. {
  740. orderNo = 9;
  741. }
  742. break;
  743. case CommandType.Start_Session:
  744. {
  745. orderNo = 10;
  746. }
  747. break;
  748. case CommandType.Stop_Session:
  749. {
  750. orderNo = 11;
  751. }
  752. break;
  753. case CommandType.Reserve_Now:
  754. {
  755. orderNo = 12;
  756. }
  757. break;
  758. case CommandType.SetLocalList:
  759. {
  760. orderNo = 14;
  761. }
  762. break;
  763. case CommandType.SetChargingProfile:
  764. {
  765. orderNo = 15;
  766. }
  767. break;
  768. default:
  769. {
  770. orderNo = 18;
  771. }
  772. break;
  773. }
  774. string[] parts = Request.RequestUri.ToString().Split('/');
  775. string urlformat = "{0}//{1}/api/v1/ocpp16/command?ChargeBoxId={2}{3}&SerialNo={4}";
  776. var _innerResult = await _client.Get(string.Format(urlformat, parts[0], parts[2], ChargeBoxId, orderNo.HasValue ? "&OrderNo=" + orderNo.Value : "", SerialNo), new Dictionary<string, string>()
  777. {
  778. { "PartnerId",_CustomerId}
  779. }, _customer.GetAPIKey(new Guid(_CustomerId)));
  780. result = GetErrorDescription(_innerResult);
  781. if (_innerResult.Success)
  782. {
  783. ComandExecution _execution = JsonConvert.DeserializeObject<ComandExecution>(_innerResult.Message);
  784. CommandResultType? _cmdResult = (CommandResultType?)null;
  785. switch (_execution.Code)
  786. {
  787. case 1:
  788. {
  789. _cmdResult = CommandResultType.Accepted;
  790. }
  791. break;
  792. case 9:
  793. {
  794. _cmdResult = CommandResultType.Notsupported;
  795. }
  796. break;
  797. case 10:
  798. {
  799. _cmdResult = CommandResultType.Unknown;
  800. }
  801. break;
  802. case 26:
  803. {
  804. _cmdResult = CommandResultType.Occupied;
  805. }
  806. break;
  807. case 31:
  808. {
  809. _cmdResult = CommandResultType.Rejected;
  810. }
  811. break;
  812. case 32:
  813. {
  814. _cmdResult = CommandResultType.Failed;
  815. }
  816. break;
  817. case 254:
  818. {
  819. _cmdResult = CommandResultType.EVSE_ERROR;
  820. }
  821. break;
  822. default:
  823. {
  824. if (_execution.Detail == "Timeout") _cmdResult = CommandResultType.Timeout;
  825. if (_execution.Detail == "Waited") _cmdResult = CommandResultType.Waited;
  826. }
  827. break;
  828. }
  829. if (!_cmdResult.HasValue)
  830. {
  831. result.StatusCode = (int)CPO_StatusCode.CANT_FOUND_DATA;
  832. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CANT_FIND_RESULT;
  833. statusCode = HttpStatusCode.NotFound;
  834. }
  835. else
  836. {
  837. var _innerData = new { Result = _cmdResult.Value.ToString(), Message = _execution.Detail };
  838. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  839. result.SerialNo = _innerResult.SerialNo;
  840. result.StatusCode = (int)CPO_StatusCode.Success;
  841. result.StatusMessage = CPO_StatusMessage.Success;
  842. statusCode = HttpStatusCode.OK;
  843. }
  844. }
  845. }
  846. catch (Exception ex)
  847. {
  848. result.ErrorDetail = ex.ToString();
  849. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  850. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  851. return Request.CreateResponse(statusCode, result);
  852. }
  853. return Request.CreateResponse(statusCode, result);
  854. }
  855. [Route("version")]
  856. [ResponseType(typeof(CPOOuterResponse))]
  857. [HttpGet]
  858. public HttpResponseMessage Version(string ChargeBoxId)
  859. {
  860. var result = new CPOOuterResponse();
  861. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  862. try
  863. {
  864. ChargePointService _service = new ChargePointService();
  865. string version = _service.GetVersionbyChargeBoxId(ChargeBoxId);
  866. result.Data = version;
  867. result.StatusCode = (int)CPO_StatusCode.Success;
  868. result.StatusMessage = CPO_StatusMessage.Success;
  869. statusCode = HttpStatusCode.OK;
  870. }
  871. catch (Exception ex)
  872. {
  873. result.ErrorDetail = ex.ToString();
  874. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  875. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  876. return Request.CreateResponse(statusCode, result);
  877. }
  878. return Request.CreateResponse(statusCode, result);
  879. }
  880. [Route("activesession")]
  881. [ResponseType(typeof(CPOOuterResponse))]
  882. [HttpGet]
  883. public HttpResponseMessage ActiveSession(string ChargeBoxId, string SessionId = "", string IdTag = "")
  884. {
  885. var result = new CPOOuterResponse();
  886. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  887. try
  888. {
  889. string _CustomerId = string.Empty;
  890. if (!ContainsChargePoint(ChargeBoxId, out _CustomerId))
  891. {
  892. // 沒槍~ 沒得充...
  893. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_DOESNT_EXIST;
  894. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  895. statusCode = HttpStatusCode.BadRequest;
  896. return Request.CreateResponse(statusCode, result);
  897. }
  898. // query meter value
  899. ChargePointService _service = new ChargePointService();
  900. var transactionDatas = _service.GetActiveSessionInfo(ChargeBoxId, new List<Measurand>()
  901. { Measurand.Voltage,
  902. Measurand.Current_Import,
  903. Measurand.SoC,
  904. Measurand.Power_Active_Import,
  905. Measurand.Energy_Active_Import_Interval,
  906. Measurand.ChargingCost
  907. }, SessionId, IdTag);
  908. if (transactionDatas == null)
  909. {
  910. result.StatusCode = (int)CPO_StatusCode.CANT_FOUND_DATA;
  911. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CANT_FIND_RESULT;
  912. statusCode = HttpStatusCode.NotFound;
  913. }
  914. else
  915. {
  916. List<ActiveSession> _innerData = new List<ActiveSession>();
  917. foreach (var transactionData in transactionDatas)
  918. {
  919. string currencyText = string.IsNullOrEmpty(transactionData.Fee) ? "TWD" : transactionData.Fee.Split('|')[1];
  920. _innerData.Add(new ActiveSession()
  921. {
  922. ChargeBoxId = ChargeBoxId,
  923. SessionId = transactionData.Id,
  924. ElaspedTime = (int)DateTime.UtcNow.Subtract(transactionData.StartTime).TotalMinutes,
  925. ConnectorId = transactionData.ConnectorId,
  926. IdTag = transactionData.StartIdTag,
  927. Power = transactionData.MeterValues == null ? "0" : transactionData.MeterValues.Where(x => x.Measurand == Packet.Messages.SubTypes.Measurand.Power_Active_Import).Select(x => x.Value).FirstOrDefault(),
  928. Power_Format = transactionData.MeterValues == null ? UnitOfMeasure.W.ToString() : transactionData.MeterValues.Where(x => x.Measurand == Packet.Messages.SubTypes.Measurand.Power_Active_Import).Select(x => x.Unit.ToString()).FirstOrDefault(),
  929. Current = transactionData.MeterValues == null ? "0" : transactionData.MeterValues.Where(x => x.Measurand == Packet.Messages.SubTypes.Measurand.Current_Import).Select(x => x.Value).FirstOrDefault(),
  930. Current_Format = transactionData.MeterValues == null ? UnitOfMeasure.A.ToString() : transactionData.MeterValues.Where(x => x.Measurand == Packet.Messages.SubTypes.Measurand.Current_Import).Select(x => x.Unit.ToString()).FirstOrDefault(),
  931. Energy = transactionData.MeterValues == null ? "0" : transactionData.MeterValues.Where(x => x.Measurand == Packet.Messages.SubTypes.Measurand.Energy_Active_Import_Interval).Select(x => x.Value).FirstOrDefault(),
  932. Energy_Format = transactionData.MeterValues == null ? UnitOfMeasure.Wh.ToString() : transactionData.MeterValues.Where(x => x.Measurand == Packet.Messages.SubTypes.Measurand.Energy_Active_Import_Interval).Select(x => x.Unit.ToString()).FirstOrDefault(),
  933. Voltage = transactionData.MeterValues == null ? "0" : transactionData.MeterValues.Where(x => x.Measurand == Packet.Messages.SubTypes.Measurand.Voltage).Select(x => x.Value).FirstOrDefault(),
  934. Voltage_Format = transactionData.MeterValues == null ? UnitOfMeasure.V.ToString() : transactionData.MeterValues.Where(x => x.Measurand == Packet.Messages.SubTypes.Measurand.Voltage).Select(x => x.Unit.ToString()).FirstOrDefault(),
  935. SOC = transactionData.MeterValues == null ? "0" : transactionData.MeterValues.Where(x => x.Measurand == Packet.Messages.SubTypes.Measurand.SoC).Select(x => x.Unit.ToString()).FirstOrDefault() == null ? null : transactionData.MeterValues.Where(x => x.Measurand == Packet.Messages.SubTypes.Measurand.SoC).Select(x => x.Value).FirstOrDefault(),
  936. SOC_Format = transactionData.MeterValues == null ? UnitOfMeasure.Percent.ToString() : transactionData.MeterValues.Where(x => x.Measurand == Packet.Messages.SubTypes.Measurand.SoC).Select(x => x.Unit.ToString()).FirstOrDefault(),
  937. CurrentCost = transactionData.MeterValues == null ? "0" : transactionData.MeterValues.Where(x => x.Measurand == Packet.Messages.SubTypes.Measurand.ChargingCost).Select(x => x.Value).FirstOrDefault(),
  938. Currency = currencyText
  939. });
  940. decimal energy = decimal.Parse(_innerData[_innerData.Count - 1].Energy);
  941. energy = _innerData[_innerData.Count - 1].Energy_Format == UnitOfMeasure.Wh.ToString() ? Decimal.Divide(energy, 1000) : energy;
  942. }
  943. var _innerResponse = new { Sessions = _innerData };
  944. result.Data = JsonConvert.SerializeObject(_innerResponse, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  945. result.StatusCode = (int)CPO_StatusCode.Success;
  946. result.StatusMessage = CPO_StatusMessage.Success;
  947. statusCode = HttpStatusCode.OK;
  948. }
  949. return Request.CreateResponse(statusCode, result);
  950. }
  951. catch (Exception ex)
  952. {
  953. result.ErrorDetail = ex.ToString();
  954. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  955. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  956. return Request.CreateResponse(statusCode, result);
  957. }
  958. }
  959. [Route("completedsession")]
  960. [ResponseType(typeof(CPOOuterResponse))]
  961. [HttpGet]
  962. public HttpResponseMessage CompletedSession(string ChargeBoxId, string SessionId = "", string IdTag = "", string StartTime = "", string StopTime = "")
  963. {
  964. var result = new CPOOuterResponse();
  965. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  966. try
  967. {
  968. string _CustomerId = string.Empty;
  969. if (!ContainsChargePoint(ChargeBoxId, out _CustomerId))
  970. {
  971. // 沒槍~ 沒得充...
  972. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_DOESNT_EXIST;
  973. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  974. statusCode = HttpStatusCode.BadRequest;
  975. return Request.CreateResponse(statusCode, result);
  976. }
  977. DateTime startDt = string.IsNullOrEmpty(StartTime) ? new DateTime(1991, 1, 1) : DateTime.Parse(StartTime);
  978. DateTime stopDt = string.IsNullOrEmpty(StopTime) ? new DateTime(1991, 1, 1) : DateTime.Parse(StopTime);
  979. // query meter value
  980. ChargePointService _service = new ChargePointService();
  981. var _innerData = _service.GetSessionDetail(ChargeBoxId, SessionId, IdTag, startDt, stopDt);
  982. if (_innerData == null)
  983. {
  984. result.StatusCode = (int)CPO_StatusCode.CANT_FOUND_DATA;
  985. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CANT_FIND_SESSIONDETAIL;
  986. statusCode = HttpStatusCode.NotFound;
  987. return Request.CreateResponse(statusCode, result);
  988. }
  989. var _innerResponse = new { SessionDetails = _innerData };
  990. result.Data = JsonConvert.SerializeObject(_innerResponse, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  991. result.StatusCode = (int)CPO_StatusCode.Success;
  992. result.StatusMessage = CPO_StatusMessage.Success;
  993. statusCode = HttpStatusCode.OK;
  994. return Request.CreateResponse(statusCode, result);
  995. }
  996. catch (Exception ex)
  997. {
  998. result.ErrorDetail = ex.ToString();
  999. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  1000. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  1001. return Request.CreateResponse(statusCode, result);
  1002. }
  1003. }
  1004. [Route("statistics/charging_sessions")]
  1005. [ResponseType(typeof(CPOOuterResponse))]
  1006. [HttpPost]
  1007. async public Task<HttpResponseMessage> ChargingSessionsStatistics([FromBody] StatisticsRequest request)
  1008. {
  1009. var result = new CPOOuterResponse();
  1010. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  1011. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  1012. try
  1013. {
  1014. InternalHttpClient _client = new InternalHttpClient();
  1015. CustomerService _customer = new CustomerService();
  1016. string url = System.Web.Configuration.WebConfigurationManager.AppSettings["StatisticsAPI"] + 1;
  1017. string chargeBoxIds = GetStatisticChargeBoxIds(request.ChargeBoxIds);
  1018. HttpClientService service = new HttpClientService();
  1019. Dictionary<string, string> postData = new Dictionary<string, string>()
  1020. {
  1021. { "ChargeBoxId", chargeBoxIds },
  1022. { "Type", request.Type.ToString() },
  1023. { "StartDate",request.DateFrom.ToString(EVCBConfiguration.DATETIMEFORMAT)},
  1024. { "EndDate",request.DateTo.ToString(EVCBConfiguration.DATETIMEFORMAT)}
  1025. };
  1026. var _innerresult = await service.PostFormDataAsync(url, postData, null);
  1027. if (_innerresult.StatusCode == HttpStatusCode.OK)
  1028. {
  1029. _innerresult.Response = _innerresult.Response.Replace("item", "Title");
  1030. _innerresult.Response = _innerresult.Response.Replace("Data", "Count");
  1031. result.Data = _innerresult.Response;
  1032. result.StatusCode = (int)CPO_StatusCode.Success;
  1033. result.StatusMessage = CPO_StatusMessage.Success;
  1034. statusCode = HttpStatusCode.OK;
  1035. }
  1036. else
  1037. {
  1038. result.StatusCode = (int)CPO_StatusCode.CANT_FOUND_DATA;
  1039. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_INNERSERVICE_ERROR;
  1040. statusCode = HttpStatusCode.BadRequest;
  1041. }
  1042. }
  1043. catch (Exception ex)
  1044. {
  1045. result.ErrorDetail = ex.ToString();
  1046. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  1047. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  1048. return Request.CreateResponse(statusCode, result);
  1049. }
  1050. return Request.CreateResponse(statusCode, result);
  1051. }
  1052. [Route("statistics/energy_delivered")]
  1053. [ResponseType(typeof(CPOOuterResponse))]
  1054. [HttpPost]
  1055. async public Task<HttpResponseMessage> Energy_Delivered([FromBody] StatisticsRequest request)
  1056. {
  1057. var result = new CPOOuterResponse();
  1058. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  1059. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  1060. try
  1061. {
  1062. InternalHttpClient _client = new InternalHttpClient();
  1063. CustomerService _customer = new CustomerService();
  1064. string url = System.Web.Configuration.WebConfigurationManager.AppSettings["StatisticsAPI"] + 2;
  1065. string chargeBoxIds = GetStatisticChargeBoxIds(request.ChargeBoxIds);
  1066. HttpClientService service = new HttpClientService();
  1067. Dictionary<string, string> postData = new Dictionary<string, string>()
  1068. {
  1069. { "ChargeBoxId",chargeBoxIds },
  1070. { "Type", request.Type.ToString() },
  1071. { "StartDate",request.DateFrom.ToString(EVCBConfiguration.DATETIMEFORMAT)},
  1072. { "EndDate",request.DateTo.ToString(EVCBConfiguration.DATETIMEFORMAT)}
  1073. };
  1074. var _innerresult = await service.PostFormDataAsync(url, postData, null);
  1075. if (_innerresult.StatusCode == HttpStatusCode.OK)
  1076. {
  1077. _innerresult.Response = _innerresult.Response.Replace("item", "Title");
  1078. _innerresult.Response = _innerresult.Response.Replace("Data", "DeliveredEnergy");
  1079. result.Data = _innerresult.Response;
  1080. result.StatusCode = (int)CPO_StatusCode.Success;
  1081. result.StatusMessage = CPO_StatusMessage.Success;
  1082. statusCode = HttpStatusCode.OK;
  1083. }
  1084. else
  1085. {
  1086. result.StatusCode = (int)CPO_StatusCode.CANT_FOUND_DATA;
  1087. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_INNERSERVICE_ERROR;
  1088. statusCode = HttpStatusCode.BadRequest;
  1089. }
  1090. }
  1091. catch (Exception ex)
  1092. {
  1093. result.ErrorDetail = ex.ToString();
  1094. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  1095. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  1096. return Request.CreateResponse(statusCode, result);
  1097. }
  1098. return Request.CreateResponse(statusCode, result);
  1099. }
  1100. [Route("statistics/time_of_use")]
  1101. [ResponseType(typeof(CPOOuterResponse))]
  1102. [HttpPost]
  1103. async public Task<HttpResponseMessage> Time_of_Use([FromBody] StatisticsRequest request)
  1104. {
  1105. var result = new CPOOuterResponse();
  1106. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  1107. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  1108. try
  1109. {
  1110. InternalHttpClient _client = new InternalHttpClient();
  1111. CustomerService _customer = new CustomerService();
  1112. string url = System.Web.Configuration.WebConfigurationManager.AppSettings["StatisticsAPI"] + 3;
  1113. string chargeBoxIds = GetStatisticChargeBoxIds(request.ChargeBoxIds);
  1114. HttpClientService service = new HttpClientService();
  1115. Dictionary<string, string> postData = new Dictionary<string, string>()
  1116. {
  1117. { "ChargeBoxId",chargeBoxIds },
  1118. { "StartDate",request.DateFrom.ToString(EVCBConfiguration.DATETIMEFORMAT)},
  1119. { "EndDate",request.DateTo.ToString(EVCBConfiguration.DATETIMEFORMAT)}
  1120. };
  1121. var _innerresult = await service.PostFormDataAsync(url, postData, null);
  1122. if (_innerresult.StatusCode == HttpStatusCode.OK)
  1123. {
  1124. _innerresult.Response = _innerresult.Response.Replace("item", "Title");
  1125. _innerresult.Response = _innerresult.Response.Replace("data", "Count");
  1126. _innerresult.Response = _innerresult.Response.Replace("data2", "DeliveredEnergy");
  1127. result.Data = _innerresult.Response;
  1128. result.StatusCode = (int)CPO_StatusCode.Success;
  1129. result.StatusMessage = CPO_StatusMessage.Success;
  1130. statusCode = HttpStatusCode.OK;
  1131. }
  1132. else
  1133. {
  1134. result.StatusCode = (int)CPO_StatusCode.CANT_FOUND_DATA;
  1135. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_INNERSERVICE_ERROR;
  1136. statusCode = HttpStatusCode.BadRequest;
  1137. }
  1138. }
  1139. catch (Exception ex)
  1140. {
  1141. result.ErrorDetail = ex.ToString();
  1142. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  1143. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  1144. return Request.CreateResponse(statusCode, result);
  1145. }
  1146. return Request.CreateResponse(statusCode, result);
  1147. }
  1148. [Route("statistics/peak_load")]
  1149. [ResponseType(typeof(CPOOuterResponse))]
  1150. [HttpPost]
  1151. async public Task<HttpResponseMessage> Peak_Load([FromBody] StatisticsRequest request)
  1152. {
  1153. var result = new CPOOuterResponse();
  1154. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  1155. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  1156. try
  1157. {
  1158. InternalHttpClient _client = new InternalHttpClient();
  1159. CustomerService _customer = new CustomerService();
  1160. string url = System.Web.Configuration.WebConfigurationManager.AppSettings["StatisticsAPI"] + 4;
  1161. string chargeBoxIds = GetStatisticChargeBoxIds(request.ChargeBoxIds);
  1162. HttpClientService service = new HttpClientService();
  1163. Dictionary<string, string> postData = new Dictionary<string, string>()
  1164. {
  1165. { "ChargeBoxId", chargeBoxIds },
  1166. { "StartDate",request.DateFrom.ToString(EVCBConfiguration.DATETIMEFORMAT)},
  1167. { "EndDate",request.DateTo.ToString(EVCBConfiguration.DATETIMEFORMAT)}
  1168. };
  1169. var _innerresult = await service.PostFormDataAsync(url, postData, null);
  1170. if (_innerresult.StatusCode == HttpStatusCode.OK)
  1171. {
  1172. _innerresult.Response = _innerresult.Response.Replace("item", "Title");
  1173. _innerresult.Response = _innerresult.Response.Replace("data", "DeliveredEnergy");
  1174. result.Data = _innerresult.Response;
  1175. result.StatusCode = (int)CPO_StatusCode.Success;
  1176. result.StatusMessage = CPO_StatusMessage.Success;
  1177. statusCode = HttpStatusCode.OK;
  1178. }
  1179. else
  1180. {
  1181. result.StatusCode = (int)CPO_StatusCode.CANT_FOUND_DATA;
  1182. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_INNERSERVICE_ERROR;
  1183. statusCode = HttpStatusCode.BadRequest;
  1184. }
  1185. }
  1186. catch (Exception ex)
  1187. {
  1188. result.ErrorDetail = ex.ToString();
  1189. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  1190. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  1191. return Request.CreateResponse(statusCode, result);
  1192. }
  1193. return Request.CreateResponse(statusCode, result);
  1194. }
  1195. [Route("statistics/sessions")]
  1196. [ResponseType(typeof(CPOOuterResponse))]
  1197. [HttpPost]
  1198. async public Task<HttpResponseMessage> Sessions([FromBody] StatisticsRequest request)
  1199. {
  1200. var result = new CPOOuterResponse();
  1201. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  1202. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  1203. try
  1204. {
  1205. InternalHttpClient _client = new InternalHttpClient();
  1206. CustomerService _customer = new CustomerService();
  1207. string url = System.Web.Configuration.WebConfigurationManager.AppSettings["StatisticsAPI"] + 6;
  1208. string chargeBoxIds = GetStatisticChargeBoxIds(request.ChargeBoxIds);
  1209. HttpClientService service = new HttpClientService();
  1210. Dictionary<string, string> postData = new Dictionary<string, string>()
  1211. {
  1212. { "ChargeBoxId", chargeBoxIds },
  1213. { "StartDate",request.DateFrom.ToString(EVCBConfiguration.DATETIMEFORMAT)},
  1214. { "EndDate",request.DateTo.ToString(EVCBConfiguration.DATETIMEFORMAT)}
  1215. };
  1216. var _innerresult = await service.PostFormDataAsync(url, postData, null);
  1217. if (_innerresult.StatusCode == HttpStatusCode.OK)
  1218. {
  1219. string titles = "\"Title\":[\"ChargeBox Id\",\"Connector Id\",\"Session Id\",\"DateFrom\",\"DateTo\",\"Duration(sec)\",\"Energy(kWh)\",\"Stop Reason\"],";
  1220. _innerresult.Response = _innerresult.Response.Replace("data", "Session");
  1221. _innerresult.Response = _innerresult.Response.Insert(1, titles);
  1222. result.Data = _innerresult.Response;
  1223. result.StatusCode = (int)CPO_StatusCode.Success;
  1224. result.StatusMessage = CPO_StatusMessage.Success;
  1225. statusCode = HttpStatusCode.OK;
  1226. }
  1227. else
  1228. {
  1229. result.StatusCode = (int)CPO_StatusCode.CANT_FOUND_DATA;
  1230. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_INNERSERVICE_ERROR;
  1231. statusCode = HttpStatusCode.BadRequest;
  1232. }
  1233. }
  1234. catch (Exception ex)
  1235. {
  1236. result.ErrorDetail = ex.ToString();
  1237. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  1238. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  1239. return Request.CreateResponse(statusCode, result);
  1240. }
  1241. return Request.CreateResponse(statusCode, result);
  1242. }
  1243. [Route("statistics/fault")]
  1244. [ResponseType(typeof(CPOOuterResponse))]
  1245. [HttpPost]
  1246. async public Task<HttpResponseMessage> Fault([FromBody] StatisticsRequest request)
  1247. {
  1248. var result = new CPOOuterResponse();
  1249. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  1250. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  1251. try
  1252. {
  1253. InternalHttpClient _client = new InternalHttpClient();
  1254. CustomerService _customer = new CustomerService();
  1255. string url = System.Web.Configuration.WebConfigurationManager.AppSettings["StatisticsAPI"] + 5;
  1256. string chargeBoxIds = GetStatisticChargeBoxIds(request.ChargeBoxIds);
  1257. HttpClientService service = new HttpClientService();
  1258. Dictionary<string, string> postData = new Dictionary<string, string>()
  1259. {
  1260. { "ChargeBoxId", chargeBoxIds},
  1261. { "StartDate",request.DateFrom.ToString(EVCBConfiguration.DATETIMEFORMAT)},
  1262. { "EndDate",request.DateTo.ToString(EVCBConfiguration.DATETIMEFORMAT)}
  1263. };
  1264. var _innerresult = await service.PostFormDataAsync(url, postData, null);
  1265. if (_innerresult.StatusCode == HttpStatusCode.OK)
  1266. {
  1267. _innerresult.Response = _innerresult.Response.Replace("item", "Title");
  1268. _innerresult.Response = _innerresult.Response.Replace("data", "Count");
  1269. _innerresult.Response = _innerresult.Response.Replace("data2", "CumulativePercentage");
  1270. result.Data = _innerresult.Response;
  1271. result.StatusCode = (int)CPO_StatusCode.Success;
  1272. result.StatusMessage = CPO_StatusMessage.Success;
  1273. statusCode = HttpStatusCode.OK;
  1274. }
  1275. else
  1276. {
  1277. result.StatusCode = (int)CPO_StatusCode.CANT_FOUND_DATA;
  1278. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_INNERSERVICE_ERROR;
  1279. statusCode = HttpStatusCode.BadRequest;
  1280. }
  1281. }
  1282. catch (Exception ex)
  1283. {
  1284. result.ErrorDetail = ex.ToString();
  1285. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  1286. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  1287. return Request.CreateResponse(statusCode, result);
  1288. }
  1289. return Request.CreateResponse(statusCode, result);
  1290. }
  1291. #region CDFA
  1292. [Route("commands/defaulprice")]
  1293. [ResponseType(typeof(CPOOuterResponse))]
  1294. [HttpPost]
  1295. async public Task<HttpResponseMessage> ChargePointDefaultPrice(string ChargeBoxId, [FromBody] ChargePointDefaultPriceRequest request)
  1296. {
  1297. var result = new CPOOuterResponse();
  1298. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  1299. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  1300. try
  1301. {
  1302. string _CustomerId = string.Empty;
  1303. if (!ContainsChargePoint(ChargeBoxId, out _CustomerId))
  1304. {
  1305. // 沒槍~ 沒得充...
  1306. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_DOESNT_EXIST;
  1307. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  1308. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  1309. statusCode = HttpStatusCode.BadRequest;
  1310. return Request.CreateResponse(statusCode, result);
  1311. }
  1312. ChargePointService chargePointService = new ChargePointService();
  1313. if (!chargePointService.IsOnline(ChargeBoxId))
  1314. {
  1315. return Request.CreateResponse(HttpStatusCode.BadRequest, new ErrorResponse() { Code = 2101, Message = EVCBConfiguration.ERROR_MSG_CHARGEBOXID_ISNT_EXIST_OR_OFFLINE });
  1316. }
  1317. //create reqest
  1318. var _request = new DataTransferRequest()
  1319. {
  1320. messageId = "DefaultPrice",
  1321. vendorId = "Phihong Technology",
  1322. data = request.DefaultPrice
  1323. };
  1324. string uuid = Guid.NewGuid().ToString();
  1325. if (!AddCommandtoServer(ChargeBoxId, uuid, _request))
  1326. {
  1327. throw new Exception("Write Command Fail!!");
  1328. }
  1329. result.SerialNo = uuid;
  1330. result.Data = JsonConvert.SerializeObject(new { Result = CommandResponseType.Accepted.ToString(), Timeout = 60 });
  1331. await Task.Delay(10);
  1332. }
  1333. catch (Exception ex)
  1334. {
  1335. result.Data = JsonConvert.SerializeObject(_innerData);
  1336. result.ErrorDetail = ex.ToString();
  1337. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  1338. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  1339. return Request.CreateResponse(statusCode, result);
  1340. }
  1341. return Request.CreateResponse(statusCode, result);
  1342. }
  1343. [Route("commands/userprice")]
  1344. [ResponseType(typeof(CPOOuterResponse))]
  1345. [HttpPost]
  1346. async public Task<HttpResponseMessage> UserPrice(string ChargeBoxId, [FromBody] UserPriceRequest request)
  1347. {
  1348. var result = new CPOOuterResponse();
  1349. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  1350. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  1351. try
  1352. {
  1353. string _CustomerId = string.Empty;
  1354. if (!ContainsChargePoint(ChargeBoxId, out _CustomerId))
  1355. {
  1356. // 沒槍~ 沒得充...
  1357. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_DOESNT_EXIST;
  1358. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  1359. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  1360. statusCode = HttpStatusCode.BadRequest;
  1361. return Request.CreateResponse(statusCode, result);
  1362. }
  1363. ChargePointService chargePointService = new ChargePointService();
  1364. if (!chargePointService.IsOnline(ChargeBoxId))
  1365. {
  1366. return Request.CreateResponse(HttpStatusCode.BadRequest, new ErrorResponse() { Code = 2101, Message = EVCBConfiguration.ERROR_MSG_CHARGEBOXID_ISNT_EXIST_OR_OFFLINE });
  1367. }
  1368. //create reqest
  1369. var _request = new DataTransferRequest()
  1370. {
  1371. messageId = "SetUserPrice",
  1372. vendorId = "Phihong Technology",
  1373. data = JsonConvert.SerializeObject(request)
  1374. };
  1375. string uuid = Guid.NewGuid().ToString();
  1376. if (!AddCommandtoServer(ChargeBoxId, uuid, _request))
  1377. {
  1378. throw new Exception("Write Command Fail!!");
  1379. }
  1380. result.SerialNo = uuid;
  1381. result.Data = JsonConvert.SerializeObject(new { Result = CommandResponseType.Accepted.ToString(), Timeout = 60 });
  1382. await Task.Delay(10);
  1383. }
  1384. catch (Exception ex)
  1385. {
  1386. result.Data = JsonConvert.SerializeObject(_innerData);
  1387. result.ErrorDetail = ex.ToString();
  1388. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  1389. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  1390. return Request.CreateResponse(statusCode, result);
  1391. }
  1392. return Request.CreateResponse(statusCode, result);
  1393. }
  1394. [Route("commands/finalcost")]
  1395. [ResponseType(typeof(CPOOuterResponse))]
  1396. [HttpPost]
  1397. async public Task<HttpResponseMessage> FinalCost(string ChargeBoxId, [FromBody] FinalCostRequest request)
  1398. {
  1399. var result = new CPOOuterResponse();
  1400. HttpStatusCode statusCode = HttpStatusCode.InternalServerError;
  1401. var _innerData = new { Result = CommandResponseType.Rejected.ToString(), Timeout = 60 };
  1402. try
  1403. {
  1404. string _CustomerId = string.Empty;
  1405. if (!ContainsChargePoint(ChargeBoxId, out _CustomerId))
  1406. {
  1407. // 沒槍~ 沒得充...
  1408. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CHARGEBOXID_DOESNT_EXIST;
  1409. result.StatusCode = (int)CPO_StatusCode.CHARGEBOXID_ISNT_EXIST_OR_OFFLINE;
  1410. result.Data = JsonConvert.SerializeObject(_innerData, EVCBConfiguration.JSONSERIALIZER_FORMAT);
  1411. statusCode = HttpStatusCode.BadRequest;
  1412. return Request.CreateResponse(statusCode, result);
  1413. }
  1414. ChargePointService chargePointService = new ChargePointService();
  1415. if (!chargePointService.IsOnline(ChargeBoxId))
  1416. {
  1417. return Request.CreateResponse(HttpStatusCode.BadRequest, new ErrorResponse() { Code = 2101, Message = EVCBConfiguration.ERROR_MSG_CHARGEBOXID_ISNT_EXIST_OR_OFFLINE });
  1418. }
  1419. string text = JsonConvert.SerializeObject(request).Replace("SessionId", "txId");
  1420. //create reqest
  1421. var _request = new DataTransferRequest()
  1422. {
  1423. messageId = "DefaultPrice",
  1424. vendorId = "Phihong Technology",
  1425. data = text
  1426. };
  1427. string uuid = Guid.NewGuid().ToString();
  1428. if (!AddCommandtoServer(ChargeBoxId, uuid, _request))
  1429. {
  1430. throw new Exception("Write Command Fail!!");
  1431. }
  1432. result.SerialNo = uuid;
  1433. result.Data = JsonConvert.SerializeObject(new { Result = CommandResponseType.Accepted.ToString(), Timeout = 60 });
  1434. await Task.Delay(10);
  1435. }
  1436. catch (Exception ex)
  1437. {
  1438. result.Data = JsonConvert.SerializeObject(_innerData);
  1439. result.ErrorDetail = ex.ToString();
  1440. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_UNEXPECTEDERROR;
  1441. result.StatusCode = (int)CPO_StatusCode.UnexpectedError;
  1442. return Request.CreateResponse(statusCode, result);
  1443. }
  1444. return Request.CreateResponse(statusCode, result);
  1445. }
  1446. #endregion
  1447. private bool AddCommandtoServer(string chargeBoxId, string uuid, IRequest request)
  1448. {
  1449. bool result = false;
  1450. try
  1451. {
  1452. ServerTriggerService service = new ServerTriggerService();
  1453. service.AddMessage(chargeBoxId, uuid, request);
  1454. result = true;
  1455. }
  1456. catch (Exception ex)
  1457. {
  1458. ;
  1459. }
  1460. return result;
  1461. }
  1462. private string GetStatisticChargeBoxIds(List<string> chargeBoxIds)
  1463. {
  1464. string result = JsonConvert.SerializeObject(chargeBoxIds, Formatting.None).Replace("\"", "'");
  1465. result = result.Replace("[", "");
  1466. result = result.Replace("]", "");
  1467. return result;
  1468. }
  1469. private CPOOuterResponse GetErrorDescription(InternalHttpResult innerResponse)
  1470. {
  1471. CPOOuterResponse result = new CPOOuterResponse();
  1472. result.ErrorDetail = innerResponse.Exception == null ? null : innerResponse.Exception.ToString();
  1473. if (innerResponse.Status != HttpStatusCode.Accepted)
  1474. {
  1475. switch (innerResponse.ErrorCode)
  1476. {
  1477. #region Authorization
  1478. case 2000:
  1479. {
  1480. result.StatusCode = innerResponse.ErrorCode;
  1481. result.StatusMessage = string.Format("{0}-{1}", "InnerService", "Authorize Unexpected Error");
  1482. result.ErrorDetail = result.StatusMessage;
  1483. }
  1484. break;
  1485. case 2001:
  1486. case 2002:
  1487. case 2003:
  1488. {
  1489. result.StatusCode = innerResponse.ErrorCode;
  1490. result.StatusMessage = string.Format("{0}-{1}", "InnerService", innerResponse.Message);
  1491. }
  1492. break;
  1493. #endregion
  1494. case 2100:
  1495. case 2101:
  1496. case 2102:
  1497. case 2103:
  1498. case 2104:
  1499. case 2105:
  1500. case 2106:
  1501. {
  1502. result.StatusCode = innerResponse.ErrorCode;
  1503. result.StatusMessage = innerResponse.Message;
  1504. }
  1505. break;
  1506. case 2999:
  1507. {
  1508. result.StatusCode = innerResponse.ErrorCode;
  1509. result.StatusMessage = string.Format("{0}-{1}", "InnerService", "Unexpected Error");
  1510. result.ErrorDetail = result.StatusMessage;
  1511. }
  1512. break;
  1513. default:
  1514. {
  1515. result.StatusCode = 2998;
  1516. result.StatusMessage = CPO_StatusMessage.ERROR_MSG_CANT_FIND_ERRORCODE;
  1517. }
  1518. break;
  1519. }
  1520. }
  1521. return result;
  1522. }
  1523. }
  1524. }