Module_PsuComm.c 41 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239
  1. #include "Module_PsuComm.h"
  2. #define ARRAY_SIZE(A) (sizeof(A) / sizeof(A[0]))
  3. #define PASS 1
  4. #define FAIL -1
  5. #define YES 1
  6. #define NO 0
  7. #define DERATING 10
  8. #define SELF_TEST 0
  9. struct SysConfigAndInfo *ShmSysConfigAndInfo;
  10. struct StatusCodeData *ShmStatusCodeData;
  11. struct PsuData *ShmPsuData;
  12. void trim(char *s);
  13. int mystrcmp(char *p1,char *p2);
  14. void substr(char *dest, const char* src, unsigned int start, unsigned int cnt);
  15. void split(char **arr, char *str, const char *del);
  16. bool libInitialize = false;
  17. byte gun_count = CHAdeMO_QUANTITY + CCS_QUANTITY + GB_QUANTITY;
  18. byte getAvailableCapOffset = 5;
  19. byte deratingKeepCount = 0;
  20. float carReqVol = 0;
  21. float carReqCur = 0;
  22. float evseOutVol = 0;
  23. float evseOutCur = 0;
  24. int cmdDelayTime = 20000;
  25. void PRINTF_FUNC(char *string, ...);
  26. int StoreLogMsg(const char *fmt, ...);
  27. #define DEBUG_INFO(format, args...) StoreLogMsg("[%s:%d][%s][Info] "format, __FILE__, __LINE__, __FUNCTION__, ##args)
  28. #define DEBUG_WARN(format, args...) StoreLogMsg("[%s:%d][%s][Warn] "format, __FILE__, __LINE__, __FUNCTION__, ##args)
  29. #define DEBUG_ERROR(format, args...) StoreLogMsg("[%s:%d][%s][Error] "format, __FILE__, __LINE__, __FUNCTION__, ##args)
  30. unsigned long GetTimeoutValue(struct timeval _sour_time);
  31. unsigned long GetTimeoutValue(struct timeval _sour_time)
  32. {
  33. struct timeval _end_time;
  34. gettimeofday(&_end_time, NULL);
  35. return 1000000 * (_end_time.tv_sec - _sour_time.tv_sec) + _end_time.tv_usec - _sour_time.tv_usec;
  36. }
  37. int StoreLogMsg(const char *fmt, ...)
  38. {
  39. char Buf[4096+256];
  40. char buffer[4096];
  41. time_t CurrentTime;
  42. struct tm *tm;
  43. va_list args;
  44. va_start(args, fmt);
  45. int rc = vsnprintf(buffer, sizeof(buffer), fmt, args);
  46. va_end(args);
  47. memset(Buf,0,sizeof(Buf));
  48. CurrentTime = time(NULL);
  49. tm=localtime(&CurrentTime);
  50. sprintf(Buf,"echo \"%04d-%02d-%02d %02d:%02d:%02d - %s\" >> /Storage/SystemLog/[%04d.%02d]SystemLog",
  51. tm->tm_year+1900,tm->tm_mon+1,tm->tm_mday,tm->tm_hour,tm->tm_min,tm->tm_sec,
  52. buffer,
  53. tm->tm_year+1900,tm->tm_mon+1);
  54. system(Buf);
  55. return rc;
  56. }
  57. int DiffTimeb(struct timeb ST, struct timeb ET)
  58. {
  59. //return milli-second
  60. unsigned int StartTime,StopTime;
  61. StartTime=(unsigned int)ST.time;
  62. StopTime=(unsigned int)ET.time;
  63. return (StopTime-StartTime)*1000+ET.millitm-ST.millitm;
  64. }
  65. void PRINTF_FUNC(char *string, ...)
  66. {
  67. if (DEBUG)
  68. {
  69. va_list args;
  70. char buffer[4096];
  71. va_start(args, string);
  72. vsnprintf(buffer, sizeof(buffer), string, args);
  73. va_end(args);
  74. printf("%s \n", buffer);
  75. }
  76. }
  77. //=================================
  78. // Common routine
  79. //=================================
  80. char* getTimeString(void)
  81. {
  82. char *result=malloc(21);
  83. time_t timep;
  84. struct tm *p;
  85. time(&timep);
  86. p=gmtime(&timep);
  87. sprintf(result, "[%04d-%02d-%02d %02d:%02d:%02d]", (1900+p->tm_year), (1+p->tm_mon), p->tm_mday, p->tm_hour, p->tm_hour, p->tm_sec);
  88. return result;
  89. }
  90. void trim(char *s)
  91. {
  92. int i=0, j, k, l=0;
  93. while((s[i]==' ')||(s[i]=='\t')||(s[i]=='\n'))
  94. i++;
  95. j = strlen(s)-1;
  96. while((s[j]==' ')||(s[j]=='\t')||(s[j]=='\n'))
  97. j--;
  98. if(i==0 && j==strlen(s)-1) { }
  99. else if(i==0) s[j+1] = '\0';
  100. else {
  101. for(k=i; k<=j; k++) s[l++] = s[k];
  102. s[l] = '\0';
  103. }
  104. }
  105. int mystrcmp(char *p1,char *p2)
  106. {
  107. while(*p1==*p2)
  108. {
  109. if(*p1=='\0' || *p2=='\0')
  110. break;
  111. p1++;
  112. p2++;
  113. }
  114. if(*p1=='\0' && *p2=='\0')
  115. return(PASS);
  116. else
  117. return(FAIL);
  118. }
  119. void substr(char *dest, const char* src, unsigned int start, unsigned int cnt)
  120. {
  121. strncpy(dest, src + start, cnt);
  122. dest[cnt] = 0;
  123. }
  124. void split(char **arr, char *str, const char *del)
  125. {
  126. char *s = strtok(str, del);
  127. while(s != NULL)
  128. {
  129. *arr++ = s;
  130. s = strtok(NULL, del);
  131. }
  132. }
  133. //=================================
  134. // ReAssigned PSU Function
  135. //=================================
  136. void ReAssignedResource()
  137. {
  138. int index = 0;
  139. struct PsuModuleData PsuModule[ShmPsuData->SystemPresentPsuQuantity];
  140. for (byte i = 0; i < 4; i++)
  141. {
  142. for(byte psuCount = 0; psuCount < ShmPsuData->PsuGroup[i].GroupPresentPsuQuantity; psuCount++)
  143. {
  144. memcpy(&PsuModule[index], &ShmPsuData->PsuGroup[i].PsuModule[psuCount], sizeof(struct PsuModuleData));
  145. index++;
  146. }
  147. ShmPsuData->PsuGroup[i].GroupPresentPsuQuantity = 0;
  148. }
  149. for(int i = 0; i < ShmPsuData->SystemPresentPsuQuantity; i++)
  150. {
  151. byte group = PsuModule[i].FireWireIndex;
  152. memcpy(&ShmPsuData->PsuGroup[group].PsuModule[ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity],
  153. &PsuModule[i], sizeof(struct PsuModuleData));
  154. PRINTF_FUNC("ReAssignedResource : PhysicalID = %d, Address = %d, group = %d \n",
  155. ShmPsuData->PsuGroup[group].PsuModule[ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity].PhysicalID,
  156. ShmPsuData->PsuGroup[group].PsuModule[ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity].Address,
  157. group);
  158. // printf("ReAssignedResource : PhysicalID = %d, Address = %d, group = %d \n",
  159. // ShmPsuData->PsuGroup[group].PsuModule[ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity].PhysicalID,
  160. // ShmPsuData->PsuGroup[group].PsuModule[ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity].Address,
  161. // group);
  162. PsuAddressAssignment(ShmPsuData->PsuGroup[group].PsuModule[ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity].PhysicalID,
  163. group);
  164. ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity++;
  165. }
  166. }
  167. //=================================
  168. // Save data to share memory Function
  169. //=================================
  170. bool FindChargingInfoData(byte target, struct ChargingInfoData **chargingData)
  171. {
  172. for (byte index = 0; index < CHAdeMO_QUANTITY; index++)
  173. {
  174. if (ShmSysConfigAndInfo->SysInfo.ChademoChargingData[index].Index == target)
  175. {
  176. chargingData[target] = &ShmSysConfigAndInfo->SysInfo.ChademoChargingData[index];
  177. return true;
  178. }
  179. }
  180. for (byte index = 0; index < CCS_QUANTITY; index++)
  181. {
  182. if (ShmSysConfigAndInfo->SysInfo.CcsChargingData[index].Index == target)
  183. {
  184. chargingData[target] = &ShmSysConfigAndInfo->SysInfo.CcsChargingData[index];
  185. return true;
  186. }
  187. }
  188. for (byte index = 0; index < GB_QUANTITY; index++)
  189. {
  190. if (ShmSysConfigAndInfo->SysInfo.GbChargingData[index].Index == target)
  191. {
  192. chargingData[target] = &ShmSysConfigAndInfo->SysInfo.GbChargingData[index];
  193. return true;
  194. }
  195. }
  196. return false;
  197. }
  198. //=================================
  199. // Alarm code mapping to share memory Function
  200. //=================================
  201. // 檢查 Byte 中某個 Bit 的值
  202. // _byte : 欲改變的 byte
  203. // _bit : 該 byte 的第幾個 bit
  204. unsigned char mask_table[] = { 0x01, 0x02, 0x04, 0x08, 0x10, 0x20, 0x40, 0x80 };
  205. unsigned char DetectBitValue(unsigned char _byte, unsigned char _bit)
  206. {
  207. return ( _byte & mask_table[_bit] ) != 0x00;
  208. }
  209. void AbnormalStopAnalysis(byte gun_index, int errCode)
  210. {
  211. for (char i = 0; i < 3; i++)
  212. {
  213. unsigned char byteIndex = (errCode >> (8 * i)) & 0xff;
  214. for (char bitIndex = 0; bitIndex < 8; bitIndex++)
  215. {
  216. if(DetectBitValue(byteIndex , bitIndex) == 1)
  217. {
  218. switch(byteIndex)
  219. {
  220. case 0:
  221. {
  222. if (bitIndex == 0)
  223. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuOutputShortCircuit = YES;
  224. else if (bitIndex == 5)
  225. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuDcSideShutDown = YES;
  226. }
  227. break;
  228. case 1:
  229. {
  230. if (bitIndex == 1)
  231. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuFailureAlarm = YES;
  232. else if (bitIndex == 2)
  233. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuProtectionAlarm = YES;
  234. else if (bitIndex == 3)
  235. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuFanFailureAlarm = YES;
  236. else if (bitIndex == 4)
  237. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuCriticalPointOTP = YES;
  238. else if (bitIndex == 5)
  239. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuDcSideShutDown = YES;
  240. }
  241. break;
  242. case 2:
  243. {
  244. if (bitIndex == 1)
  245. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuDuplicateID = YES;
  246. if (bitIndex == 2)
  247. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuThreePhaseOnputImbalance = YES;
  248. else if (bitIndex == 3)
  249. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuThreePhaseInputInadequate = YES;
  250. else if (bitIndex == 4)
  251. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuThreePhaseInputInadequate = YES;
  252. else if (bitIndex == 5)
  253. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuInputUVP = YES;
  254. else if (bitIndex == 6)
  255. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuInputOVP = YES;
  256. }
  257. break;
  258. }
  259. }
  260. else
  261. {
  262. switch (byteIndex) {
  263. case 0: {
  264. if (bitIndex == 0)
  265. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuOutputShortCircuit = NO;
  266. else if (bitIndex == 5)
  267. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuDcSideShutDown = NO;
  268. }
  269. break;
  270. case 1: {
  271. if (bitIndex == 1)
  272. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuFailureAlarm = NO;
  273. else if (bitIndex == 2)
  274. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuProtectionAlarm = NO;
  275. else if (bitIndex == 3)
  276. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuFanFailureAlarm = NO;
  277. else if (bitIndex == 4)
  278. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuCriticalPointOTP = NO;
  279. else if (bitIndex == 5)
  280. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuDcSideShutDown = NO;
  281. }
  282. break;
  283. case 2: {
  284. if (bitIndex == 1)
  285. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuDuplicateID = NO;
  286. if (bitIndex == 2)
  287. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuThreePhaseOnputImbalance = NO;
  288. else if (bitIndex == 3)
  289. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuThreePhaseInputInadequate = NO;
  290. else if (bitIndex == 4)
  291. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuThreePhaseInputInadequate = NO;
  292. else if (bitIndex == 5)
  293. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuInputUVP = NO;
  294. else if (bitIndex == 6)
  295. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuInputOVP = NO;
  296. }
  297. break;
  298. }
  299. }
  300. }
  301. }
  302. }
  303. //=================================
  304. // Callback Function
  305. //=================================
  306. void GetPsuRequestCallback(byte phy_id, char *serial_number)
  307. {
  308. if (ShmSysConfigAndInfo->SysInfo.AcContactorStatus == NO)
  309. return;
  310. // ********************** 每次送電後,需判斷要把所有的模塊分配到哪個 Group **********************
  311. byte group = 0;
  312. if(ShmSysConfigAndInfo->SysInfo.BootingStatus == BOOTTING || gun_count == 1)
  313. {
  314. // 初始化狀態,則直接先分配到同個群
  315. group = 0;
  316. }
  317. else
  318. {
  319. group = ShmSysConfigAndInfo->SysInfo.CurGunSelected;
  320. }
  321. bool isNewPsu = true;
  322. for (byte index = 0; index < ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity; index++)
  323. {
  324. if (ShmPsuData->PsuGroup[group].PsuModule[index].PhysicalID == phy_id &&
  325. strncmp((char *)ShmPsuData->PsuGroup[group].PsuModule[index].SerialNumber, serial_number, 7) == 0)
  326. {
  327. isNewPsu = false;
  328. }
  329. }
  330. if (isNewPsu)
  331. {
  332. ShmPsuData->SystemPresentPsuQuantity++;
  333. PRINTF_FUNC("get psu********Membar = %d, group = %d \n", ShmPsuData->SystemPresentPsuQuantity, group);
  334. if (ShmPsuData->Work_Step >= _TEST_LINE_STEP && ShmPsuData->Work_Step <= _TEST_COMPLETE)
  335. {
  336. // 已經進入火線上的驗證動作
  337. ShmPsuData->NeedBackTest = YES;
  338. }
  339. else if (ShmPsuData->Work_Step == _WORK_CHARGING)
  340. {
  341. // 一旦進入火線,分配一個不會用到的給該模塊
  342. group++;
  343. }
  344. ShmPsuData->PsuGroup[group].PsuModule[ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity].Address = ShmPsuData->SystemPresentPsuQuantity;
  345. ShmPsuData->PsuGroup[group].PsuModule[ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity].PhysicalID = phy_id;
  346. ShmPsuData->PsuGroup[group].PsuModule[ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity].AssignID = (group >> 6) + ShmPsuData->SystemPresentPsuQuantity;
  347. strcpy((char *)ShmPsuData->PsuGroup[group].PsuModule[ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity].SerialNumber, serial_number);
  348. ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity++;
  349. byte isFind = false;
  350. for (byte index = 0; index < conn_1_count; index++)
  351. {
  352. PRINTF_FUNC("connector_1[%d] = %d, phy_id = %d \n", index, connector_1[index], phy_id);
  353. if (connector_1[index] == phy_id)
  354. {
  355. isFind = true;
  356. ShmPsuData->PsuGroup[group].PsuModule[ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity].FireWireIndex = 0;
  357. break;
  358. }
  359. }
  360. if (!isFind)
  361. {
  362. for (byte index = 0; index < conn_2_count; index++)
  363. {
  364. PRINTF_FUNC("connector_2[%d] = %d, phy_id = %d \n", index, connector_2[index], phy_id);
  365. if (connector_2[index] == phy_id)
  366. {
  367. isFind = true;
  368. ShmPsuData->PsuGroup[group].PsuModule[ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity].FireWireIndex = 1;
  369. break;
  370. }
  371. }
  372. }
  373. //PsuAddressAssignment(phy_id, serial_number, ShmPsuData->SystemPresentPsuQuantity, group);
  374. PsuAddressAssignment(phy_id, group);
  375. if (ShmPsuData->Work_Step != _WORK_CHARGING)
  376. {
  377. ShmPsuData->GroupCount = group + 1;
  378. }
  379. }
  380. }
  381. void SaveStatusCallback(byte group, byte address, char cri_temp1, int alarm)
  382. {
  383. //EVSE
  384. for (byte index = 0; index < ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity; index++)
  385. {
  386. if (ShmPsuData->PsuGroup[group].PsuModule[index].PhysicalID == address)
  387. {
  388. ShmPsuData->PsuGroup[group].PsuModule[index].CriticalTemp1 = cri_temp1;
  389. ShmPsuData->PsuGroup[group].PsuModule[index].AlarmCode = alarm;
  390. AbnormalStopAnalysis(group, alarm);
  391. break;
  392. }
  393. }
  394. }
  395. //模組三向輸入電壓
  396. void SavePresentInputVoltageCallback(byte address, unsigned short vol1, unsigned short vol2, unsigned short vol3)
  397. {
  398. //EVSE
  399. //search group
  400. for (byte groupIndex = 0; groupIndex < ShmPsuData->GroupCount; groupIndex++)
  401. {
  402. for (byte index = 0; index < ShmPsuData->PsuGroup[groupIndex].GroupPresentPsuQuantity; index++)
  403. {
  404. //search id
  405. if (ShmPsuData->PsuGroup[groupIndex].PsuModule[index].PhysicalID == address)
  406. {
  407. //update module msg
  408. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].InputVoltageL1 = vol1;
  409. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].InputVoltageL2 = vol2;
  410. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].InputVoltageL3 = vol3;
  411. break;
  412. }
  413. }
  414. }
  415. }
  416. // 模塊輸出的電壓電流
  417. void SavePresentOutputCallback(byte address, unsigned short out_vol, unsigned short out_cur)
  418. {
  419. unsigned short outputVol = 0;
  420. unsigned short outputCur = 0;
  421. unsigned short group = 0;
  422. bool isChange = false;
  423. // PSU
  424. for (byte groupIndex = 0; groupIndex < ShmPsuData->GroupCount; groupIndex++)
  425. {
  426. for (int index = 0; index < ShmPsuData->PsuGroup[groupIndex].GroupPresentPsuQuantity; index++)
  427. {
  428. if (ShmPsuData->PsuGroup[groupIndex].PsuModule[index].PhysicalID == address)
  429. {
  430. //如果英飛源模組不是 ver1.09 版使用模組輸出電壓
  431. /*
  432. if(InfyPwrModelVerIs109 == 0)
  433. {
  434. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].PresentOutputVoltage = out_vol;
  435. }
  436. */
  437. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].PresentOutputVoltage = out_vol;
  438. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].PresentOutputCurrent = out_cur;
  439. for (int loop = 0; loop < ShmPsuData->PsuGroup[groupIndex].GroupPresentPsuQuantity; loop++)
  440. {
  441. //update voltage
  442. if (ShmPsuData->PsuGroup[groupIndex].PsuModule[loop].PresentOutputVoltage > outputVol)
  443. {
  444. outputVol = ShmPsuData->PsuGroup[groupIndex].PsuModule[loop].PresentOutputVoltage;
  445. }
  446. //update total current
  447. outputCur += ShmPsuData->PsuGroup[groupIndex].PsuModule[index].PresentOutputCurrent;
  448. group = groupIndex;
  449. isChange = true;
  450. }
  451. }
  452. /*
  453. if (ShmPsuData->PsuGroup[group].PsuModule[index].PresentOutputVoltage > outputVol)
  454. outputVol = ShmPsuData->PsuGroup[group].PsuModule[index].PresentOutputVoltage;
  455. outputCur += ShmPsuData->PsuGroup[group].PsuModule[index].PresentOutputCurrent;
  456. */
  457. }
  458. }
  459. if (isChange)
  460. {
  461. // PSU Group
  462. // 電壓
  463. ShmPsuData->PsuGroup[group].GroupPresentOutputVoltage = outputVol;
  464. // 電流
  465. ShmPsuData->PsuGroup[group].GroupPresentOutputCurrent = outputCur;
  466. //EVSE - 槍端的輸出電壓
  467. chargingInfo[group]->PresentChargingVoltage = ShmPsuData->PsuGroup[group].GroupPresentOutputVoltage;
  468. //EVSE - 槍端的輸出電流
  469. chargingInfo[group]->PresentChargingCurrent = ShmPsuData->PsuGroup[group].GroupPresentOutputCurrent;
  470. }
  471. //printf("GroupPresentOutputVoltage = %d \n", ShmPsuData->PsuGroup[group].GroupPresentOutputVoltage);
  472. //printf("GroupPresentOutputCurrent = %d \n", ShmPsuData->PsuGroup[group].GroupPresentOutputCurrent);
  473. }
  474. //PSU able_power = KW (單位 0.1) exp. 300 = 30kw
  475. //PSU able_cur = A (單位 0.1) exp. 400 = 40A
  476. void SaveAvailableCapCallback(byte address, unsigned short maxv, unsigned short minv, unsigned short able_cur, unsigned short able_power)
  477. {
  478. unsigned int power = 0;
  479. unsigned int current = 0;
  480. unsigned int power_derating = 0;
  481. unsigned int current_derating = 0;
  482. unsigned int group = 0;
  483. bool isChange = false;
  484. //bool sameGroup = false;
  485. //search group
  486. //printf("GroupCount = %d \n", ShmPsuData->GroupCount);
  487. for (byte groupIndex = 0; groupIndex < ShmPsuData->GroupCount; groupIndex++)
  488. {
  489. //printf("GroupPresentPsuQuantity = %d \n", ShmPsuData->PsuGroup[groupIndex].GroupPresentPsuQuantity);
  490. for (int index = 0; index < ShmPsuData->PsuGroup[groupIndex].GroupPresentPsuQuantity; index++)
  491. {
  492. //search group-id
  493. //printf("PhysicalID = %d, address = %d \n", ShmPsuData->PsuGroup[groupIndex].PsuModule[index].PhysicalID, address);
  494. if (ShmPsuData->PsuGroup[groupIndex].PsuModule[index].PhysicalID == address)
  495. {
  496. //先更新該模組資訊
  497. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].AvailablePower = able_power;
  498. //電壓在 150V 時使用額定電流
  499. if(ShmPsuData->PsuGroup[groupIndex].PsuModule[index].PresentOutputVoltage < 1500)
  500. {
  501. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].AvailableCurrent = able_cur;
  502. }
  503. //如果英飛源模組不是 ver1.09 版 或 (如果英飛源模組是 ver1.09 版但回應可輸出電流有誤則使用額定報文可輸出電流)
  504. /*
  505. if(InfyPwrModelVerIs109 == 0 ||
  506. (InfyPwrModelVerIs109 == 1 && ShmPsuData->PsuGroup[groupIndex].PsuModule[index].AvailableCurrent == 0))
  507. {
  508. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].AvailableCurrent = able_cur;
  509. }
  510. */
  511. //該對應的模組群重新計算總合
  512. for (int loop = 0; loop < ShmPsuData->PsuGroup[groupIndex].GroupPresentPsuQuantity; loop++)
  513. {
  514. // 降載
  515. if (ShmSysConfigAndInfo->SysInfo.ReAssignedFlag >= _REASSIGNED_GET_NEW_CAP &&
  516. ShmSysConfigAndInfo->SysInfo.ReAssignedFlag < _REASSIGNED_COMP)
  517. {
  518. if (ShmPsuData->PsuGroup[group].PsuModule[index].FireWireIndex == group)
  519. {
  520. power_derating += ShmPsuData->PsuGroup[group].PsuModule[index].AvailablePower;
  521. current_derating += ShmPsuData->PsuGroup[group].PsuModule[index].AvailableCurrent;
  522. }
  523. }
  524. power += ShmPsuData->PsuGroup[groupIndex].PsuModule[loop].AvailablePower;
  525. current += ShmPsuData->PsuGroup[groupIndex].PsuModule[loop].AvailableCurrent;
  526. group = groupIndex;
  527. isChange = true;
  528. }
  529. }
  530. }
  531. }
  532. if (current_derating == 0)
  533. {
  534. current_derating = current;
  535. }
  536. if (power_derating == 0)
  537. {
  538. power_derating = power;
  539. }
  540. if (isChange)
  541. {
  542. // PSU Group
  543. // Available Power
  544. ShmPsuData->PsuGroup[group].GroupAvailablePower = power;
  545. // Available Current
  546. ShmPsuData->PsuGroup[group].GroupAvailableCurrent = current;
  547. chargingInfo[group]->MaximumChargingVoltage = maxv;
  548. chargingInfo[group]->AvailableChargingCurrent = ShmPsuData->PsuGroup[group].GroupAvailableCurrent;
  549. chargingInfo[group]->AvailableChargingPower = ShmPsuData->PsuGroup[group].GroupAvailablePower;
  550. chargingInfo[group]->DeratingChargingCurrent = current_derating;
  551. chargingInfo[group]->DeratingChargingPower = power_derating;
  552. PRINTF_FUNC("group = %d, AvailableChargingCurrent = %f, GroupAvailablePower = %f, DeratingChargingCurrent = %f, DeratingChargingPower = %f \n",
  553. group, chargingInfo[group]->AvailableChargingCurrent, chargingInfo[group]->AvailableChargingPower,
  554. chargingInfo[group]->DeratingChargingCurrent, chargingInfo[group]->DeratingChargingPower);
  555. }
  556. }
  557. void GetBarCodeCallback(byte address, char *serial_number , unsigned short module_ver)
  558. {
  559. //EVSE
  560. for (byte groupIndex = 0; groupIndex < ShmPsuData->GroupCount; groupIndex++)
  561. {
  562. for (byte index = 0; index < ShmPsuData->PsuGroup[groupIndex].GroupPresentPsuQuantity; index++)
  563. {
  564. if (ShmPsuData->PsuGroup[groupIndex].PsuModule[index].PhysicalID == address)
  565. {
  566. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].FwVersion[0] = (module_ver >> 8) & 0xFF;
  567. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].FwVersion[1] = (module_ver) & 0xFF;
  568. //strcpy((char *)ShmPsuData->PsuGroup[groupIndex].PsuModule[ShmPsuData->PsuGroup[groupIndex].GroupPresentPsuQuantity].SerialNumber, serial_number);
  569. }
  570. }
  571. }
  572. }
  573. void GetMiscInfoCallback(byte address, unsigned short CmdType , unsigned int value)
  574. {
  575. //EVSE
  576. for (byte groupIndex = 0; groupIndex < ShmPsuData->GroupCount; groupIndex++)
  577. {
  578. for (byte index = 0; index < ShmPsuData->PsuGroup[groupIndex].GroupPresentPsuQuantity; index++)
  579. {
  580. if (ShmPsuData->PsuGroup[groupIndex].PsuModule[index].PhysicalID == address)
  581. {
  582. if(CmdType == MISC_REQCMD_DC_BOARD_TMP){
  583. //數值未處理
  584. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].CriticalTemp2 = (byte)value;
  585. }else if(CmdType == MISC_REQCMD_PFC_BOARD_TMP){
  586. //數值未處理
  587. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].CriticalTemp3 = (byte)value;
  588. }else if(CmdType == MISC_REQCMD_FAN_SPEED){
  589. //數值未處理
  590. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].FanSpeed_1 = (unsigned short)value;
  591. }
  592. }
  593. }
  594. }
  595. //暫定如果有回 misc 就認定英飛源為 1.9 版
  596. //InfyPwrModelVerIs109 = 1;
  597. //printf("Get Misc : %d \n",InfyPwrModelVerIs109);
  598. }
  599. void SaveHardwareVersion(byte group, byte address, int hw_ver)
  600. {
  601. //EVSE
  602. for (byte index = 0; index < ShmPsuData->PsuGroup[group].GroupPresentPsuQuantity; index++)
  603. {
  604. if (ShmPsuData->PsuGroup[group].PsuModule[index].Address == address)
  605. {
  606. ShmPsuData->PsuGroup[group].PsuModule[index].FwVersion[0] = (hw_ver >> 24) & 0xFF;
  607. ShmPsuData->PsuGroup[group].PsuModule[index].FwVersion[1] = (hw_ver >> 16) & 0xFF;
  608. ShmPsuData->PsuGroup[group].PsuModule[index].FwVersion[2] = (hw_ver >> 8) & 0xFF;
  609. ShmPsuData->PsuGroup[group].PsuModule[index].FwVersion[3] = hw_ver & 0xFF;
  610. break;
  611. }
  612. }
  613. }
  614. //Vext 模組二極體後電壓
  615. //Iavail 模組目前因環境因素的真實能輸出電流
  616. void SavePresentModeleVextIavailCallback(byte address, unsigned short Vext, unsigned short Iavail)
  617. {
  618. //EVSE
  619. //search group
  620. for (byte groupIndex = 0; groupIndex < ShmPsuData->GroupCount; groupIndex++)
  621. {
  622. for (byte index = 0; index < ShmPsuData->PsuGroup[groupIndex].GroupPresentPsuQuantity; index++)
  623. {
  624. //search id
  625. if (ShmPsuData->PsuGroup[groupIndex].PsuModule[index].PhysicalID == address)
  626. {
  627. //update module msg
  628. //ShmPsuData->PsuGroup[groupIndex].PsuModule[index].PresentOutputVoltage = Vext;
  629. //
  630. if(ShmPsuData->PsuGroup[groupIndex].PsuModule[index].PresentOutputVoltage >= 1500)
  631. {
  632. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].AvailableCurrent = Iavail;
  633. }
  634. //printf("Vext = %d I = %d \n", Vext,Iavail);
  635. break;
  636. }
  637. }
  638. }
  639. }
  640. void GetOutputPowerSwitchStatusCallback(byte address, unsigned char value)
  641. {
  642. for (byte groupIndex = 0; groupIndex < ShmPsuData->GroupCount; groupIndex++)
  643. {
  644. for (byte index = 0; index < ShmPsuData->PsuGroup[groupIndex].GroupPresentPsuQuantity; index++)
  645. {
  646. if (ShmPsuData->PsuGroup[groupIndex].PsuModule[index].PhysicalID == address)
  647. {
  648. //printf("PowerSwitch = %d, group = %d, address = %d \n", value, group, address);
  649. if(value){
  650. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].OutputPowerSwitch = 0x00;
  651. }else{
  652. ShmPsuData->PsuGroup[groupIndex].PsuModule[index].OutputPowerSwitch = 0x01;
  653. }
  654. break;
  655. }
  656. }
  657. }
  658. }
  659. //==========================================
  660. // Init all share memory
  661. //==========================================
  662. int InitShareMemory()
  663. {
  664. int result = PASS;
  665. int MeterSMId;
  666. //creat ShmSysConfigAndInfo
  667. if ((MeterSMId = shmget(ShmSysConfigAndInfoKey, sizeof(struct SysConfigAndInfo), 0777)) < 0)
  668. {
  669. #ifdef SystemLogMessage
  670. DEBUG_ERROR("shmget ShmSysConfigAndInfo NG %d \n");
  671. #endif
  672. result = FAIL;
  673. }
  674. else if ((ShmSysConfigAndInfo = shmat(MeterSMId, NULL, 0)) == (void *) -1)
  675. {
  676. #ifdef SystemLogMessage
  677. DEBUG_ERROR("shmat ShmSysConfigAndInfo NG \n");
  678. #endif
  679. result = FAIL;
  680. }
  681. else
  682. {}
  683. //creat ShmStatusCodeData
  684. if ((MeterSMId = shmget(ShmStatusCodeKey, sizeof(struct StatusCodeData), 0777)) < 0)
  685. {
  686. #ifdef SystemLogMessage
  687. DEBUG_ERROR("shmget ShmStatusCodeData NG \n");
  688. #endif
  689. result = FAIL;
  690. }
  691. else if ((ShmStatusCodeData = shmat(MeterSMId, NULL, 0)) == (void *) -1)
  692. {
  693. #ifdef SystemLogMessage
  694. DEBUG_ERROR("shmat ShmStatusCodeData NG \n");
  695. #endif
  696. result = FAIL;
  697. }
  698. else
  699. {}
  700. //creat ShmPsuData
  701. if ((MeterSMId = shmget(ShmPsuKey, sizeof(struct PsuData), 0777)) < 0)
  702. {
  703. #ifdef SystemLogMessage
  704. DEBUG_ERROR("shmget ShmPsuData NG \n");
  705. #endif
  706. result = FAIL;
  707. }
  708. else if ((ShmPsuData = shmat(MeterSMId, NULL, 0)) == (void *) -1)
  709. {
  710. #ifdef SystemLogMessage
  711. DEBUG_ERROR("shmat ShmPsuData NG \n");
  712. #endif
  713. result = FAIL;
  714. }
  715. memset(ShmPsuData,0,sizeof(struct PsuData));
  716. return result;
  717. }
  718. //================================================
  719. // Main process
  720. //================================================
  721. void InitialPsuData()
  722. {
  723. ShmPsuData->SystemPresentPsuQuantity = 0;
  724. for (byte _groupCount = 0; _groupCount < ARRAY_SIZE(ShmPsuData->PsuGroup); _groupCount++)
  725. {
  726. ShmPsuData->PsuGroup[_groupCount].GroupPresentPsuQuantity = 0;
  727. ShmPsuData->PsuGroup[_groupCount].GroupAvailablePower = 0;
  728. ShmPsuData->PsuGroup[_groupCount].GroupAvailableCurrent = 0;
  729. }
  730. ShmPsuData->Work_Step = _INIT_PSU_STATUS;
  731. }
  732. void Initialization()
  733. {
  734. bool isPass = false;
  735. while(!isPass)
  736. {
  737. isPass = true;
  738. for (byte _index = 0; _index < _gunCount; _index++)
  739. {
  740. if (!FindChargingInfoData(_index, &chargingInfo[0]))
  741. {
  742. DEBUG_ERROR("EvComm (main) : FindChargingInfoData false \n");
  743. isPass = false;
  744. break;
  745. }
  746. }
  747. }
  748. conn_1_count = sizeof(connector_1)/sizeof(connector_1[0]);
  749. conn_2_count = sizeof(connector_2)/sizeof(connector_2[0]);
  750. }
  751. int main(void)
  752. {
  753. PRINTF_FUNC("Psu Task boot .... \n");
  754. if(InitShareMemory() == FAIL)
  755. {
  756. #ifdef SystemLogMessage
  757. DEBUG_ERROR("InitShareMemory NG\n");
  758. #endif
  759. if(ShmStatusCodeData != NULL)
  760. {
  761. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.FailToCreateShareMemory = 1;
  762. }
  763. sleep(5);
  764. return 0;
  765. }
  766. PRINTF_FUNC("InitShareMemory OK\n");
  767. // register callback function
  768. GetPsuAddressReq(&GetPsuRequestCallback);
  769. RefreshSerialNumber(&GetBarCodeCallback);
  770. RefreshVextAndIavail(&SavePresentModeleVextIavailCallback);
  771. RefreshMiscInfo(&GetMiscInfoCallback);
  772. RefreshStatus(&SaveStatusCallback);
  773. RefreshInputVol(&SavePresentInputVoltageCallback);
  774. RefreshGetOutput(&SavePresentOutputCallback);
  775. RefreshAvailableCap(&SaveAvailableCapCallback);
  776. RefreshOutputPowerSwitch(&GetOutputPowerSwitchStatusCallback);
  777. // initial object
  778. InitialPsuData();
  779. Initialization();
  780. libInitialize = InitialCommunication();
  781. byte priorityLow = 1;
  782. byte isInitialComp = NO;
  783. //main loop
  784. while (libInitialize)
  785. {
  786. // 斷電狀態
  787. if (ShmSysConfigAndInfo->SysInfo.AcContactorStatus == NO)
  788. {
  789. //一但 AC Off PSU 斷電全部的 PSU Group ID 會全部清 0
  790. if (!isInitialComp)
  791. {
  792. InitialPsuData();
  793. ShmPsuData->Work_Step = ASSIGN_START;
  794. isInitialComp = YES;
  795. }
  796. sleep(1);
  797. continue;
  798. }
  799. else
  800. isInitialComp = NO;
  801. // update psu fw req
  802. // if(psu update req ?)
  803. // {
  804. //
  805. // continue;
  806. // }
  807. // 自檢失敗
  808. if (ShmPsuData->Work_Step == _NO_WORKING)
  809. {
  810. PRINTF_FUNC("== PSU == self test fail. \n");
  811. sleep(5);
  812. }
  813. switch(ShmPsuData->Work_Step)
  814. {
  815. case ASSIGN_START:
  816. {
  817. PRINTF_FUNC("== PSU == ASSIGN_COMP \n");
  818. gettimeofday(&_id_assign_time, NULL);
  819. ShmPsuData->Work_Step = ASSIGN_COMP;
  820. }
  821. break;
  822. case ASSIGN_COMP:
  823. {
  824. if (priorityLow == 1)
  825. {
  826. //如果還未取得模組數量
  827. if(ShmPsuData->SystemPresentPsuQuantity == 0)
  828. {
  829. EnableDipAddrMode();
  830. usleep(cmdDelayTime);
  831. //發送取得目前全部模組數量 (英飛源開機須等待讓模組互相通訊)
  832. RequestModuleTotalMumbert();
  833. usleep(cmdDelayTime);
  834. }
  835. //己取得模組數量 (目前還未分配群組所以都使用預設 0)
  836. else
  837. {
  838. for (byte psuIndex = 0; psuIndex < ShmPsuData->PsuGroup[0].GroupPresentPsuQuantity; psuIndex++)
  839. {
  840. //get status
  841. GetStatus(0, NONE_CARE_ADDRESS);
  842. usleep(cmdDelayTime);
  843. //get barcode & ver
  844. GetSerialNumber(0, NONE_CARE_ADDRESS);
  845. usleep(cmdDelayTime);
  846. GetMiscInfo(0, NONE_CARE_ADDRESS, MISC_REQCMD_DC_BOARD_TMP);
  847. usleep(cmdDelayTime);
  848. GetMiscInfo(0, NONE_CARE_ADDRESS, MISC_REQCMD_PFC_BOARD_TMP);
  849. usleep(cmdDelayTime);
  850. GetMiscInfo(0, NONE_CARE_ADDRESS, MISC_REQCMD_PFC_BOARD_TMP);
  851. usleep(cmdDelayTime);
  852. }
  853. }
  854. //printf("Get Misc2 : %d \n",InfyPwrModelVerIs109);
  855. }
  856. priorityLow >= 20 ? priorityLow = 1 : priorityLow++;
  857. // 等待 15 秒
  858. if (GetTimeoutValue(_id_assign_time) >= 15000000)
  859. {
  860. ShmPsuData->Work_Step = ENABLE_POW;
  861. PRINTF_FUNC("INFYPWR Num = %d \n", ShmPsuData->SystemPresentPsuQuantity);
  862. PRINTF_FUNC("== PSU == ENABLE_POW \n");
  863. }
  864. }
  865. break;
  866. case ENABLE_POW:
  867. {
  868. if (ShmSysConfigAndInfo->SysInfo.BootingStatus == BOOTTING)
  869. {
  870. // 電樁在 Booting 的狀態 - 自檢
  871. PRINTF_FUNC("== PSU == _TEST_LINE_STEP \n");
  872. ShmPsuData->Work_Step = _TEST_LINE_STEP;
  873. }
  874. else
  875. {
  876. PRINTF_FUNC("== PSU == _WORK_CHARGING \n");
  877. ShmPsuData->Work_Step = _WORK_CHARGING;
  878. gettimeofday(&_workModePriority_time, NULL);
  879. }
  880. }
  881. break;
  882. case _TEST_LINE_STEP:
  883. {
  884. PRINTF_FUNC("cur total psu count = %d \n", ShmPsuData->SystemPresentPsuQuantity);
  885. if (ShmPsuData->PsuGroup[0].GroupPresentPsuQuantity <= 0)
  886. {
  887. sleep(1);
  888. continue;
  889. }
  890. ShmPsuData->Work_Step = _TEST_POWER_STEP;
  891. }
  892. break;
  893. case _TEST_POWER_STEP:
  894. {
  895. if(!_chkTotalCapStart)
  896. {
  897. _chkTotalCapStart = true;
  898. gettimeofday(&_chk_cap_time, NULL);
  899. }
  900. for (byte groupIndex = 0; groupIndex < ShmPsuData->GroupCount; groupIndex++)
  901. {
  902. GetStatus(groupIndex, NONE_CARE_ADDRESS);
  903. usleep(cmdDelayTime);
  904. //infypwr v1.9 (如果沒回也沒差)
  905. //GetVextAndIavail(SET_MODULE_CMD, NONE_CARE_ADDRESS);
  906. //usleep(cmdDelayTime);
  907. }
  908. for (byte psuCount = 0; psuCount < ShmPsuData->SystemPresentPsuQuantity; psuCount++)
  909. {
  910. GetAvailableCap(psuCount, NONE_CARE_ADDRESS, 0);
  911. }
  912. usleep(cmdDelayTime);
  913. if (GetTimeoutValue(_chk_cap_time) >= 2000000)
  914. {
  915. PRINTF_FUNC("AvailableChargingCurrent = %f, AvailableChargingPower = %f \n",
  916. chargingInfo[0]->AvailableChargingCurrent, chargingInfo[0]->AvailableChargingPower);
  917. for (byte index = 0; index < ShmPsuData->PsuGroup[0].GroupPresentPsuQuantity; index++)
  918. {
  919. PRINTF_FUNC("index = %d, fire index = %d, phy addr = %d \n",
  920. index, recordPsuData[index]._fire_index, recordPsuData[index]._phy_addr);
  921. }
  922. PRINTF_FUNC("== PSU == TEST_COMPLETE \n");
  923. ShmPsuData->Work_Step = _TEST_COMPLETE;
  924. }
  925. }
  926. break;
  927. case _TEST_COMPLETE:
  928. {
  929. priorityLow = 1;
  930. sleep(1);
  931. }
  932. break;
  933. case _WORK_CHARGING:
  934. {
  935. int time = GetTimeoutValue(_workModePriority_time) / 1000;
  936. //printf("GroupCount = %d \n", ShmPsuData->GroupCount);
  937. //printf("cur total psu count = %d \n", ShmPsuData->SystemPresentPsuQuantity);
  938. // 智能分配 : 檢查該槍是否有模塊有用,有則無須重新分配直接進入充電
  939. if (ShmSysConfigAndInfo->SysInfo.ReAssignedFlag == _REASSIGNED_PREPARE)
  940. {
  941. if (ShmPsuData->PsuGroup[ShmSysConfigAndInfo->SysInfo.CurGunSelected].GroupPresentPsuQuantity > 0)
  942. {
  943. PRINTF_FUNC("=============Smart Charging : _REASSIGNED_NONE============= Step 0 \n");
  944. ShmSysConfigAndInfo->SysInfo.ReAssignedFlag = _REASSIGNED_NONE;
  945. }
  946. else
  947. {
  948. PRINTF_FUNC("=============Smart Charging : _REASSIGNED_GET_NEW_CAP============= Step 2 \n");
  949. ShmSysConfigAndInfo->SysInfo.ReAssignedFlag = _REASSIGNED_GET_NEW_CAP;
  950. }
  951. }
  952. if (time > 1000)
  953. {
  954. for (byte psuCount = 0; psuCount < ShmPsuData->SystemPresentPsuQuantity; psuCount++)
  955. {
  956. GetAvailableCap(psuCount, NONE_CARE_ADDRESS, 0);
  957. }
  958. usleep(cmdDelayTime);
  959. }
  960. for (byte groupIndex = 0; groupIndex < ShmPsuData->GroupCount; groupIndex++)
  961. {
  962. if (time > 1000)
  963. {
  964. GetStatus(groupIndex, NONE_CARE_ADDRESS);
  965. usleep(cmdDelayTime);
  966. /*
  967. GetMiscInfo(SET_GROUP_CMD, 0, MISC_REQCMD_DC_BOARD_TMP);
  968. usleep(cmdDelayTime);
  969. GetMiscInfo(SET_GROUP_CMD, 0, MISC_REQCMD_PFC_BOARD_TMP);
  970. usleep(cmdDelayTime);
  971. GetMiscInfo(SET_GROUP_CMD, 0, MISC_REQCMD_PFC_BOARD_TMP);
  972. usleep(cmdDelayTime);
  973. */
  974. if (ShmSysConfigAndInfo->SysInfo.ReAssignedFlag == _REASSIGNED_GET_NEW_CAP)
  975. {
  976. if (groupIndex != ShmSysConfigAndInfo->SysInfo.CurGunSelected)
  977. {
  978. if (chargingInfo[groupIndex]->SystemStatus >= S_CHARGING && chargingInfo[groupIndex]->SystemStatus <= S_COMPLETE)
  979. {
  980. if (chargingInfo[groupIndex]->DeratingChargingCurrent < chargingInfo[groupIndex]->AvailableChargingCurrent)
  981. {
  982. // 車端需求電流降低至降載的電流
  983. PRINTF_FUNC("Smart Charging : index = %d, EvBatterytargetCurrent = %f, DeratingChargingCurrent = %f \n",
  984. groupIndex, chargingInfo[groupIndex]->EvBatterytargetCurrent, chargingInfo[groupIndex]->DeratingChargingCurrent);
  985. if ((chargingInfo[groupIndex]->EvBatterytargetCurrent <= chargingInfo[groupIndex]->DeratingChargingCurrent) ||
  986. deratingKeepCount >= DERATING)
  987. {
  988. // 車端降載完成
  989. PRINTF_FUNC("=============Smart Charging : _REASSIGNED_MAIN============= Step 3 \n");
  990. ShmSysConfigAndInfo->SysInfo.ReAssignedFlag = _REASSIGNED_MAIN;
  991. }
  992. else
  993. {
  994. deratingKeepCount++;
  995. }
  996. }
  997. }
  998. }
  999. }
  1000. else
  1001. deratingKeepCount = 0;
  1002. if (ShmSysConfigAndInfo->SysInfo.ReAssignedFlag == _REASSIGNED_MAIN)
  1003. {
  1004. PRINTF_FUNC("=============Smart Charging : _REASSIGNED_ADJUST============= Step 4 \n");
  1005. //重新分配模組
  1006. ReAssignedResource();
  1007. gettimeofday(&_derating_time, NULL);
  1008. ShmSysConfigAndInfo->SysInfo.ReAssignedFlag = _REASSIGNED_ADJUST;
  1009. }
  1010. gettimeofday(&_workModePriority_time, NULL);
  1011. }
  1012. GetPresentOutput(groupIndex, NONE_CARE_ADDRESS);
  1013. usleep(cmdDelayTime);
  1014. //GetVextAndIavail(SET_MODULE_CMD, 0);
  1015. if (carReqVol != chargingInfo[groupIndex]->EvBatterytargetVoltage)
  1016. {
  1017. carReqVol = chargingInfo[groupIndex]->EvBatterytargetVoltage;
  1018. DEBUG_INFO("ev need vol = %f \n", chargingInfo[groupIndex]->EvBatterytargetVoltage);
  1019. }
  1020. if (carReqCur != chargingInfo[groupIndex]->EvBatterytargetCurrent)
  1021. {
  1022. carReqCur = chargingInfo[groupIndex]->EvBatterytargetCurrent;
  1023. DEBUG_INFO("ev need cur = %f \n", chargingInfo[groupIndex]->EvBatterytargetCurrent);
  1024. }
  1025. if (evseOutVol != chargingInfo[groupIndex]->FireChargingVoltage)
  1026. {
  1027. evseOutVol = chargingInfo[groupIndex]->FireChargingVoltage;
  1028. PRINTF_FUNC("evse output vol = %f \n", chargingInfo[groupIndex]->FireChargingVoltage);
  1029. }
  1030. if (evseOutCur != chargingInfo[groupIndex]->PresentChargingCurrent)
  1031. {
  1032. evseOutCur = chargingInfo[groupIndex]->PresentChargingCurrent;
  1033. PRINTF_FUNC("evse output cur = %f \n", chargingInfo[groupIndex]->PresentChargingCurrent);
  1034. }
  1035. // 針對各槍當前狀態,傳送需要回傳的資料指令
  1036. if (((chargingInfo[groupIndex]->SystemStatus >= S_PREPARING_FOR_EVSE && chargingInfo[groupIndex]->SystemStatus <= S_CHARGING) && chargingInfo[groupIndex]->RelayK1K2Status) ||
  1037. chargingInfo[groupIndex]->SystemStatus == S_REASSIGN ||
  1038. (chargingInfo[groupIndex]->SystemStatus >= S_CCS_PRECHARGE_ST0 && chargingInfo[groupIndex]->SystemStatus <= S_CCS_PRECHARGE_ST1))
  1039. {
  1040. if (ShmPsuData->PsuGroup[groupIndex].GroupAvailableCurrent > 0)
  1041. {
  1042. if (ShmSysConfigAndInfo->SysInfo.ReAssignedFlag >= _REASSIGNED_ADJUST &&
  1043. ShmSysConfigAndInfo->SysInfo.ReAssignedFlag < _REASSIGNED_COMP )
  1044. {
  1045. // 如果車端要求的電流超過降載,則以降載電流為主
  1046. if (chargingInfo[groupIndex]->EvBatterytargetCurrent >= chargingInfo[groupIndex]->DeratingChargingCurrent)
  1047. {
  1048. chargingInfo[groupIndex]->EvBatterytargetCurrent = chargingInfo[groupIndex]->DeratingChargingCurrent;
  1049. }
  1050. if (ShmSysConfigAndInfo->SysInfo.ReAssignedFlag == _REASSIGNED_ADJUST)
  1051. {
  1052. deratingTime = GetTimeoutValue(_derating_time) / 1000;
  1053. if (deratingTime > 3000)
  1054. {
  1055. deratingTime = 0;
  1056. PRINTF_FUNC("=============Smart Charging : _REASSIGNED_RELAY============= Step 5 \n");
  1057. ShmSysConfigAndInfo->SysInfo.ReAssignedFlag = _REASSIGNED_RELAY;
  1058. }
  1059. for(int i = 0; i < ShmPsuData->PsuGroup[groupIndex].GroupPresentPsuQuantity; i++)
  1060. {
  1061. PRINTF_FUNC("*********_REASSIGNED_ADJUST : groupIndex = %d, outputCur = %d, outputVol = %d \n",
  1062. groupIndex,
  1063. ShmPsuData->PsuGroup[groupIndex].PsuModule[i].PresentOutputCurrent,
  1064. ShmPsuData->PsuGroup[groupIndex].PsuModule[i].PresentOutputVoltage);
  1065. }
  1066. }
  1067. // 該充電槍的目標電壓與目標電流
  1068. SetPresentOutput(groupIndex, NONE_CARE_ADDRESS,
  1069. chargingInfo[groupIndex]->EvBatterytargetVoltage,
  1070. chargingInfo[groupIndex]->EvBatterytargetCurrent,
  1071. chargingInfo[groupIndex]->DeratingChargingCurrent);
  1072. usleep(cmdDelayTime);
  1073. }
  1074. else
  1075. {
  1076. // 該充電槍的目標電壓與目標電流
  1077. SetPresentOutput(groupIndex, NONE_CARE_ADDRESS,
  1078. chargingInfo[groupIndex]->EvBatterytargetVoltage,
  1079. chargingInfo[groupIndex]->EvBatterytargetCurrent,
  1080. chargingInfo[groupIndex]->AvailableChargingCurrent);
  1081. usleep(cmdDelayTime);
  1082. }
  1083. }
  1084. if (chargingInfo[groupIndex]->EvBatterytargetVoltage == 0)
  1085. {
  1086. EnableOutputPower(groupIndex, NONE_CARE_ADDRESS, SWITCH_OFF);
  1087. usleep(cmdDelayTime);
  1088. EnableGreenLedFlash(groupIndex , NONE_CARE_ADDRESS , SWITCH_OFF);
  1089. usleep(cmdDelayTime);
  1090. }
  1091. else
  1092. {
  1093. EnableOutputPower(groupIndex, NONE_CARE_ADDRESS, SWITCH_ON);
  1094. usleep(cmdDelayTime);
  1095. EnableGreenLedFlash(groupIndex , NONE_CARE_ADDRESS, SWITCH_ON);
  1096. usleep(cmdDelayTime);
  1097. }
  1098. }
  1099. else if (chargingInfo[groupIndex]->SystemStatus >= S_TERMINATING &&
  1100. chargingInfo[groupIndex]->SystemStatus <= S_COMPLETE)
  1101. {
  1102. SetPresentOutput(groupIndex, NONE_CARE_ADDRESS, ZERO_VOL, ZERO_CUR, chargingInfo[groupIndex]->AvailableChargingCurrent);
  1103. usleep(cmdDelayTime);
  1104. EnableGreenLedFlash(groupIndex , NONE_CARE_ADDRESS , SWITCH_OFF);
  1105. usleep(cmdDelayTime);
  1106. EnableOutputPower(groupIndex, NONE_CARE_ADDRESS, SWITCH_OFF);
  1107. usleep(cmdDelayTime);
  1108. }
  1109. }
  1110. priorityLow >= 200 ? priorityLow = 1 : priorityLow++;
  1111. break;
  1112. }
  1113. }
  1114. }
  1115. return FAIL;
  1116. }