Module_PsuComm.c 41 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244
  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. sleep(5);
  819. gettimeofday(&_id_assign_time, NULL);
  820. ShmPsuData->Work_Step = ASSIGN_COMP;
  821. }
  822. break;
  823. case ASSIGN_COMP:
  824. {
  825. if (priorityLow == 1)
  826. {
  827. //如果還未取得模組數量
  828. if(ShmPsuData->SystemPresentPsuQuantity == 0)
  829. {
  830. EnableDipAddrMode();
  831. usleep(cmdDelayTime);
  832. //發送取得目前全部模組數量 (英飛源開機須等待讓模組互相通訊)
  833. RequestModuleTotalMumbert();
  834. usleep(cmdDelayTime);
  835. }
  836. //己取得模組數量 (目前還未分配群組所以都使用預設 0)
  837. else
  838. {
  839. for (byte psuIndex = 0; psuIndex < ShmPsuData->PsuGroup[0].GroupPresentPsuQuantity; psuIndex++)
  840. {
  841. //get status
  842. GetStatus(0, NONE_CARE_ADDRESS);
  843. usleep(cmdDelayTime);
  844. //get barcode & ver
  845. GetSerialNumber(0, NONE_CARE_ADDRESS);
  846. usleep(cmdDelayTime);
  847. GetMiscInfo(0, NONE_CARE_ADDRESS, MISC_REQCMD_DC_BOARD_TMP);
  848. usleep(cmdDelayTime);
  849. GetMiscInfo(0, NONE_CARE_ADDRESS, MISC_REQCMD_PFC_BOARD_TMP);
  850. usleep(cmdDelayTime);
  851. GetMiscInfo(0, NONE_CARE_ADDRESS, MISC_REQCMD_PFC_BOARD_TMP);
  852. usleep(cmdDelayTime);
  853. }
  854. }
  855. //printf("Get Misc2 : %d \n",InfyPwrModelVerIs109);
  856. }
  857. priorityLow >= 20 ? priorityLow = 1 : priorityLow++;
  858. // 等待 10 秒
  859. if (GetTimeoutValue(_id_assign_time) >= 10000000)
  860. {
  861. ShmPsuData->Work_Step = ENABLE_POW;
  862. PRINTF_FUNC("INFYPWR Num = %d \n", ShmPsuData->SystemPresentPsuQuantity);
  863. PRINTF_FUNC("== PSU == ENABLE_POW \n");
  864. }
  865. }
  866. break;
  867. case ENABLE_POW:
  868. {
  869. if (ShmSysConfigAndInfo->SysInfo.BootingStatus == BOOTTING)
  870. {
  871. // 電樁在 Booting 的狀態 - 自檢
  872. PRINTF_FUNC("== PSU == _TEST_LINE_STEP \n");
  873. ShmPsuData->Work_Step = _TEST_LINE_STEP;
  874. }
  875. else
  876. {
  877. PRINTF_FUNC("== PSU == _WORK_CHARGING \n");
  878. ShmPsuData->Work_Step = _WORK_CHARGING;
  879. gettimeofday(&_workModePriority_time, NULL);
  880. }
  881. }
  882. break;
  883. case _TEST_LINE_STEP:
  884. {
  885. PRINTF_FUNC("cur total psu count = %d \n", ShmPsuData->SystemPresentPsuQuantity);
  886. if (ShmPsuData->PsuGroup[0].GroupPresentPsuQuantity <= 0)
  887. {
  888. sleep(1);
  889. // 顯示錯誤
  890. ShmStatusCodeData->AlarmCode.AlarmEvents.bits.PsuNoResource = YES;
  891. continue;
  892. }
  893. ShmPsuData->Work_Step = _TEST_POWER_STEP;
  894. }
  895. break;
  896. case _TEST_POWER_STEP:
  897. {
  898. if(!_chkTotalCapStart)
  899. {
  900. _chkTotalCapStart = true;
  901. gettimeofday(&_chk_cap_time, NULL);
  902. }
  903. // 初始化、關閉所有的模塊
  904. //EnableOutputPower(0, NONE_CARE_ADDRESS, SWITCH_OFF);
  905. for (byte groupIndex = 0; groupIndex < ShmPsuData->GroupCount; groupIndex++)
  906. {
  907. GetStatus(groupIndex, NONE_CARE_ADDRESS);
  908. usleep(cmdDelayTime);
  909. }
  910. for (byte psuCount = 0; psuCount < ShmPsuData->SystemPresentPsuQuantity; psuCount++)
  911. {
  912. GetAvailableCap(psuCount, NONE_CARE_ADDRESS, 0);
  913. }
  914. usleep(cmdDelayTime);
  915. if (GetTimeoutValue(_chk_cap_time) >= 2000000)
  916. {
  917. PRINTF_FUNC("AvailableChargingCurrent = %f, AvailableChargingPower = %f \n",
  918. chargingInfo[0]->AvailableChargingCurrent, chargingInfo[0]->AvailableChargingPower);
  919. for (byte index = 0; index < ShmPsuData->PsuGroup[0].GroupPresentPsuQuantity; index++)
  920. {
  921. PRINTF_FUNC("index = %d, fire index = %d, phy addr = %d \n",
  922. index, recordPsuData[index]._fire_index, recordPsuData[index]._phy_addr);
  923. }
  924. PRINTF_FUNC("== PSU == TEST_COMPLETE \n");
  925. ShmPsuData->Work_Step = _TEST_COMPLETE;
  926. }
  927. }
  928. break;
  929. case _TEST_COMPLETE:
  930. {
  931. priorityLow = 1;
  932. sleep(1);
  933. }
  934. break;
  935. case _WORK_CHARGING:
  936. {
  937. int time = GetTimeoutValue(_workModePriority_time) / 1000;
  938. //printf("GroupCount = %d \n", ShmPsuData->GroupCount);
  939. //printf("cur total psu count = %d \n", ShmPsuData->SystemPresentPsuQuantity);
  940. // 智能分配 : 檢查該槍是否有模塊有用,有則無須重新分配直接進入充電
  941. if (ShmSysConfigAndInfo->SysInfo.ReAssignedFlag == _REASSIGNED_PREPARE)
  942. {
  943. if (ShmPsuData->PsuGroup[ShmSysConfigAndInfo->SysInfo.CurGunSelected].GroupPresentPsuQuantity > 0)
  944. {
  945. PRINTF_FUNC("=============Smart Charging : _REASSIGNED_NONE============= Step 0 \n");
  946. ShmSysConfigAndInfo->SysInfo.ReAssignedFlag = _REASSIGNED_NONE;
  947. }
  948. else
  949. {
  950. PRINTF_FUNC("=============Smart Charging : _REASSIGNED_GET_NEW_CAP============= Step 2 \n");
  951. ShmSysConfigAndInfo->SysInfo.ReAssignedFlag = _REASSIGNED_GET_NEW_CAP;
  952. }
  953. }
  954. if (time > 1000)
  955. {
  956. for (byte psuCount = 0; psuCount < ShmPsuData->GroupCount; psuCount++)
  957. {
  958. GetAvailableCap(psuCount, NONE_CARE_ADDRESS, 0);
  959. }
  960. usleep(cmdDelayTime);
  961. }
  962. for (byte groupIndex = 0; groupIndex < ShmPsuData->GroupCount; groupIndex++)
  963. {
  964. if (time > 1000)
  965. {
  966. GetStatus(groupIndex, NONE_CARE_ADDRESS);
  967. usleep(cmdDelayTime);
  968. /*
  969. GetMiscInfo(SET_GROUP_CMD, 0, MISC_REQCMD_DC_BOARD_TMP);
  970. usleep(cmdDelayTime);
  971. GetMiscInfo(SET_GROUP_CMD, 0, MISC_REQCMD_PFC_BOARD_TMP);
  972. usleep(cmdDelayTime);
  973. GetMiscInfo(SET_GROUP_CMD, 0, MISC_REQCMD_PFC_BOARD_TMP);
  974. usleep(cmdDelayTime);
  975. */
  976. // if (ShmSysConfigAndInfo->SysInfo.ReAssignedFlag == _REASSIGNED_GET_NEW_CAP)
  977. // {
  978. // if (groupIndex != ShmSysConfigAndInfo->SysInfo.CurGunSelected)
  979. // {
  980. // if (chargingInfo[groupIndex]->SystemStatus >= S_CHARGING && chargingInfo[groupIndex]->SystemStatus <= S_COMPLETE)
  981. // {
  982. // if (chargingInfo[groupIndex]->DeratingChargingCurrent < chargingInfo[groupIndex]->AvailableChargingCurrent)
  983. // {
  984. // // 車端需求電流降低至降載的電流
  985. // PRINTF_FUNC("Smart Charging : index = %d, EvBatterytargetCurrent = %f, DeratingChargingCurrent = %f \n",
  986. // groupIndex, chargingInfo[groupIndex]->EvBatterytargetCurrent, chargingInfo[groupIndex]->DeratingChargingCurrent);
  987. //
  988. // if ((chargingInfo[groupIndex]->EvBatterytargetCurrent <= chargingInfo[groupIndex]->DeratingChargingCurrent) ||
  989. // deratingKeepCount >= DERATING)
  990. // {
  991. // // 車端降載完成
  992. // PRINTF_FUNC("=============Smart Charging : _REASSIGNED_MAIN============= Step 3 \n");
  993. // ShmSysConfigAndInfo->SysInfo.ReAssignedFlag = _REASSIGNED_MAIN;
  994. // }
  995. // else
  996. // {
  997. // deratingKeepCount++;
  998. // }
  999. // }
  1000. // }
  1001. // }
  1002. // }
  1003. // else
  1004. // deratingKeepCount = 0;
  1005. //
  1006. // if (ShmSysConfigAndInfo->SysInfo.ReAssignedFlag == _REASSIGNED_MAIN)
  1007. // {
  1008. // PRINTF_FUNC("=============Smart Charging : _REASSIGNED_ADJUST============= Step 4 \n");
  1009. // //重新分配模組
  1010. // ReAssignedResource();
  1011. // gettimeofday(&_derating_time, NULL);
  1012. // ShmSysConfigAndInfo->SysInfo.ReAssignedFlag = _REASSIGNED_ADJUST;
  1013. // }
  1014. gettimeofday(&_workModePriority_time, NULL);
  1015. }
  1016. GetPresentOutput(groupIndex, NONE_CARE_ADDRESS);
  1017. usleep(cmdDelayTime);
  1018. //GetVextAndIavail(SET_MODULE_CMD, 0);
  1019. if (chargingInfo[groupIndex]->EvBatterytargetVoltage > 0 &&
  1020. carReqVol != chargingInfo[groupIndex]->EvBatterytargetVoltage)
  1021. {
  1022. carReqVol = chargingInfo[groupIndex]->EvBatterytargetVoltage;
  1023. DEBUG_INFO("ev need vol = %f \n", chargingInfo[groupIndex]->EvBatterytargetVoltage);
  1024. }
  1025. if (chargingInfo[groupIndex]->EvBatterytargetCurrent > 0 &&
  1026. carReqCur != chargingInfo[groupIndex]->EvBatterytargetCurrent)
  1027. {
  1028. carReqCur = chargingInfo[groupIndex]->EvBatterytargetCurrent;
  1029. DEBUG_INFO("ev need cur = %f \n", chargingInfo[groupIndex]->EvBatterytargetCurrent);
  1030. }
  1031. if (chargingInfo[groupIndex]->FireChargingVoltage > 0 &&
  1032. evseOutVol != chargingInfo[groupIndex]->FireChargingVoltage)
  1033. {
  1034. evseOutVol = chargingInfo[groupIndex]->FireChargingVoltage;
  1035. PRINTF_FUNC("groupIndex = %d, evse output vol = %f \n", groupIndex, chargingInfo[groupIndex]->FireChargingVoltage);
  1036. }
  1037. if (chargingInfo[groupIndex]->PresentChargingCurrent > 0 &&
  1038. evseOutCur != chargingInfo[groupIndex]->PresentChargingCurrent)
  1039. {
  1040. evseOutCur = chargingInfo[groupIndex]->PresentChargingCurrent;
  1041. PRINTF_FUNC("groupIndex = %d, evse output cur = %f \n", groupIndex, chargingInfo[groupIndex]->PresentChargingCurrent);
  1042. }
  1043. // 針對各槍當前狀態,傳送需要回傳的資料指令
  1044. if (((chargingInfo[groupIndex]->SystemStatus >= S_PREPARING_FOR_EVSE && chargingInfo[groupIndex]->SystemStatus <= S_CHARGING) && chargingInfo[groupIndex]->RelayK1K2Status) ||
  1045. chargingInfo[groupIndex]->SystemStatus == S_REASSIGN ||
  1046. (chargingInfo[groupIndex]->SystemStatus >= S_CCS_PRECHARGE_ST0 && chargingInfo[groupIndex]->SystemStatus <= S_CCS_PRECHARGE_ST1))
  1047. {
  1048. if (ShmPsuData->PsuGroup[groupIndex].GroupAvailableCurrent > 0)
  1049. {
  1050. // if (ShmSysConfigAndInfo->SysInfo.ReAssignedFlag >= _REASSIGNED_ADJUST &&
  1051. // ShmSysConfigAndInfo->SysInfo.ReAssignedFlag < _REASSIGNED_COMP )
  1052. // {
  1053. // // 如果車端要求的電流超過降載,則以降載電流為主
  1054. // if (chargingInfo[groupIndex]->EvBatterytargetCurrent >= chargingInfo[groupIndex]->DeratingChargingCurrent)
  1055. // {
  1056. // chargingInfo[groupIndex]->EvBatterytargetCurrent = chargingInfo[groupIndex]->DeratingChargingCurrent;
  1057. // }
  1058. //
  1059. // if (ShmSysConfigAndInfo->SysInfo.ReAssignedFlag == _REASSIGNED_ADJUST)
  1060. // {
  1061. // deratingTime = GetTimeoutValue(_derating_time) / 1000;
  1062. // if (deratingTime > 3000)
  1063. // {
  1064. // deratingTime = 0;
  1065. // PRINTF_FUNC("=============Smart Charging : _REASSIGNED_RELAY============= Step 5 \n");
  1066. // ShmSysConfigAndInfo->SysInfo.ReAssignedFlag = _REASSIGNED_RELAY;
  1067. // }
  1068. //
  1069. // for(int i = 0; i < ShmPsuData->PsuGroup[groupIndex].GroupPresentPsuQuantity; i++)
  1070. // {
  1071. // PRINTF_FUNC("*********_REASSIGNED_ADJUST : groupIndex = %d, outputCur = %d, outputVol = %d \n",
  1072. // groupIndex,
  1073. // ShmPsuData->PsuGroup[groupIndex].PsuModule[i].PresentOutputCurrent,
  1074. // ShmPsuData->PsuGroup[groupIndex].PsuModule[i].PresentOutputVoltage);
  1075. // }
  1076. // }
  1077. //
  1078. // // 該充電槍的目標電壓與目標電流
  1079. // SetPresentOutput(groupIndex, NONE_CARE_ADDRESS,
  1080. // chargingInfo[groupIndex]->EvBatterytargetVoltage,
  1081. // chargingInfo[groupIndex]->EvBatterytargetCurrent,
  1082. // chargingInfo[groupIndex]->DeratingChargingCurrent);
  1083. // usleep(cmdDelayTime);
  1084. // }
  1085. // else
  1086. {
  1087. // 該充電槍的目標電壓與目標電流
  1088. SetPresentOutput(groupIndex, NONE_CARE_ADDRESS,
  1089. chargingInfo[groupIndex]->EvBatterytargetVoltage,
  1090. chargingInfo[groupIndex]->EvBatterytargetCurrent,
  1091. chargingInfo[groupIndex]->AvailableChargingCurrent);
  1092. usleep(cmdDelayTime);
  1093. }
  1094. }
  1095. if (chargingInfo[groupIndex]->EvBatterytargetVoltage == 0)
  1096. {
  1097. EnableOutputPower(groupIndex, NONE_CARE_ADDRESS, SWITCH_OFF);
  1098. usleep(cmdDelayTime);
  1099. EnableGreenLedFlash(groupIndex , NONE_CARE_ADDRESS , SWITCH_OFF);
  1100. usleep(cmdDelayTime);
  1101. }
  1102. else
  1103. {
  1104. EnableOutputPower(groupIndex, NONE_CARE_ADDRESS, SWITCH_ON);
  1105. usleep(cmdDelayTime);
  1106. EnableGreenLedFlash(groupIndex , NONE_CARE_ADDRESS, SWITCH_ON);
  1107. usleep(cmdDelayTime);
  1108. }
  1109. }
  1110. else if (chargingInfo[groupIndex]->SystemStatus >= S_TERMINATING &&
  1111. chargingInfo[groupIndex]->SystemStatus <= S_COMPLETE)
  1112. {
  1113. SetPresentOutput(groupIndex, NONE_CARE_ADDRESS, ZERO_VOL, ZERO_CUR, chargingInfo[groupIndex]->AvailableChargingCurrent);
  1114. usleep(cmdDelayTime);
  1115. EnableGreenLedFlash(groupIndex , NONE_CARE_ADDRESS , SWITCH_OFF);
  1116. usleep(cmdDelayTime);
  1117. EnableOutputPower(groupIndex, NONE_CARE_ADDRESS, SWITCH_OFF);
  1118. usleep(cmdDelayTime);
  1119. }
  1120. }
  1121. priorityLow >= 200 ? priorityLow = 1 : priorityLow++;
  1122. break;
  1123. }
  1124. }
  1125. }
  1126. return FAIL;
  1127. }