RFID.c 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768
  1. #include <stdio.h> /*標準輸入輸出定義*/
  2. #include <stdlib.h> /*標準函數庫定義*/
  3. #include <string.h>
  4. #include <stdint.h>
  5. #include "../Config.h"
  6. #include "../Log/log.h"
  7. #include "../Define/define.h"
  8. #include "../ShareMemory/shmMem.h"
  9. #include "../SelectGun/SelectGun.h"
  10. #include "../DataBase/DataBase.h"
  11. #include "main.h"
  12. #include "../timeout.h"
  13. static DcCommonInfo *ShmDcCommonData = NULL;
  14. static SelectGunInfo *ShmSelectGunInfo = NULL;
  15. static struct SysInfoData *pSysInfo = NULL;
  16. #define PREAUTHMONEY 888
  17. bool isDeductDb_ready;
  18. static RecordTransactionInfo LocalTransactionInfo;
  19. //------------------------------------------------------------------------------
  20. static char *rfidPortName = "/dev/ttyS2";
  21. static bool isCardScan = false;
  22. //------------------------------------------------------------------------------
  23. static bool canStartCharging(void)
  24. {
  25. uint8_t index = 0;
  26. char buf2[16] = "";
  27. memset(buf2, 0, ARRAY_SIZE(buf2));
  28. struct OCPP16Data *ShmOCPP16Data = (struct OCPP16Data *)GetShmOCPP16Data();
  29. for (index = 0; index < strlen((char *)ShmOCPP16Data->Authorize.ResponseIdTagInfo.Status); index++) {
  30. sprintf(buf2 + (index - 1) * 2, "%02X", ShmOCPP16Data->Authorize.ResponseIdTagInfo.Status[index]);
  31. }
  32. sprintf(buf2, "%s", ShmOCPP16Data->Authorize.ResponseIdTagInfo.Status);
  33. // 因為無法得知實際的長度,所以只能用搜尋的方式
  34. if (strcmp(buf2, "Accepted") == EQUAL) {
  35. return true;
  36. }
  37. return false;
  38. }
  39. bool isAutorCompleteHandle(/*uint8_t *authorizeIndex*/)
  40. {
  41. // uint8_t i = 0;
  42. struct SysConfigData *pSysConfig = (struct SysConfigData *)GetShmSysConfigData();
  43. //struct ChargingInfoData *pDcChargingInfo = NULL;
  44. //struct SysInfoData *pSysInfo = (struct SysInfoData *)GetShmSysInfoData();
  45. // 透過後臺停止充電的判斷
  46. if (isAuthorizedComplete()) {
  47. // 判斷後台回覆狀態
  48. if (canStartCharging() == false) {
  49. strcpy((char *)pSysConfig->UserId, "");
  50. ClearAuthorizedFlag();
  51. }
  52. return true;
  53. }
  54. return false;
  55. /*
  56. if (*(authorizeIndex) != NO_DEFINE) {
  57. pDcChargingInfo = (struct ChargingInfoData *)GetDcChargingInfoData(*(authorizeIndex));
  58. if (pSysConfig->OfflinePolicy == _OFFLINE_POLICY_LOCAL_LIST &&
  59. strcmp((char *)pDcChargingInfo->StartUserId, "") != EQUAL) {
  60. // 先找 AC
  61. if (*(authorizeIndex) == DEFAULT_AC_INDEX) {
  62. AcChargingTerminalProcess();
  63. } else {
  64. ChargingTerminalProcess(*(authorizeIndex));
  65. }
  66. }
  67. strcpy((char *)pSysConfig->UserId, "");
  68. *(authorizeIndex) = NO_DEFINE;
  69. }
  70. ClearAuthorizedFlag();
  71. } else if (pSysConfig->OfflinePolicy == _OFFLINE_POLICY_LOCAL_LIST) {
  72. // 白名單驗證
  73. for (i = 0; i < 10; i++) {
  74. if (strcmp((char *)pSysConfig->LocalWhiteCard[i], "") == EQUAL) {
  75. continue;
  76. }
  77. if (strcmp((char *)pSysConfig->LocalWhiteCard[i], (char *)pSysConfig->UserId) == EQUAL) {
  78. ChargingTerminalProcess(*(authorizeIndex));
  79. strcpy((char *)pSysConfig->UserId, "");
  80. ClearAuthorizedFlag();
  81. break;
  82. }
  83. }
  84. }*/
  85. }
  86. bool RfidStopCharging(void)
  87. {
  88. //當前沒有選槍
  89. struct SysConfigData *pSysConfig = (struct SysConfigData *)GetShmSysConfigData();
  90. struct SysInfoData *pSysInfo = (struct SysInfoData *)GetShmSysInfoData();
  91. if (getConfirmSelectedGun(pSysInfo->CurGunSelected) == FAIL ) {
  92. strcpy((char *)pSysConfig->UserId, "");
  93. return false;
  94. }
  95. struct ChargingInfoData *pDcChargingInfo = (struct ChargingInfoData *)GetDcChargingInfoData(pSysInfo->CurGunSelected);
  96. if (pDcChargingInfo->isRemoteStart) {
  97. } else {
  98. if (strcmp((char *)pSysConfig->UserId, (char *)pDcChargingInfo->StartUserId) == EQUAL) {
  99. ChargingTerminalProcess(pSysInfo->CurGunSelected);
  100. strcpy((char *)pSysConfig->UserId, "");
  101. log_info("index = %d, card number = %s, UserId = %s ",
  102. pSysInfo->CurGunSelected,
  103. pDcChargingInfo->StartUserId,
  104. pSysConfig->UserId);
  105. return true;
  106. } else {
  107. strcpy((char *)pSysConfig->UserId, "");
  108. return false;
  109. }
  110. }
  111. return false;
  112. }
  113. static void UserScanFunction(void)
  114. {
  115. // bool idleReq = false;
  116. //uint8_t i = 0;
  117. //uint8_t stopReq = NO_DEFINE;
  118. //char value[32] = {0};
  119. //static uint8_t _authorizeIndex = NO_DEFINE;
  120. struct SysConfigData *pSysConfig = (struct SysConfigData *)GetShmSysConfigData();
  121. struct SysInfoData *pSysInfo = (struct SysInfoData *)GetShmSysInfoData();
  122. //struct ChargingInfoData *pAcChargingInfo = (struct ChargingInfoData *)GetAcChargingInfoData(0);
  123. struct ChargingInfoData *pDcChargingInfo = NULL;
  124. //GunIndexInfo *pGunIndexInfo = (GunIndexInfo *)GetGunIndexInfo();
  125. // 當前非驗證的狀態
  126. if (IsAuthorizingMode()) {
  127. isAutorCompleteHandle(/*&_authorizeIndex*/);
  128. }
  129. //當前沒有選槍
  130. /*
  131. if (getConfirmSelectedGun(pSysInfo->CurGunSelected) == FAIL) {
  132. strcpy((char *)pSysConfig->UserId, "");
  133. return;
  134. }*/
  135. // 先判斷現在是否可以提供刷卡
  136. // 1. 如果當前沒有槍是閒置狀態,則無提供刷卡功能
  137. // 2. 停止充電
  138. //if (pSysInfo->PageIndex == _LCM_ERROR) {
  139. if (pSysInfo->SystemPage == _PAGE_MAINTAIN) {
  140. strcpy((char *)pSysConfig->UserId, "");
  141. return;
  142. }
  143. /*
  144. for (i = 0; i < pSysConfig->TotalConnectorCount; i++) {
  145. pDcChargingInfo = (struct ChargingInfoData *)GetDcChargingInfoData(i);
  146. if (pDcChargingInfo->SystemStatus == S_CHARGING) {
  147. stopReq = i;
  148. }
  149. if ((pDcChargingInfo->SystemStatus == S_AUTHORIZING &&
  150. pDcChargingInfo->IsAvailable == YES) ||
  151. (pGunIndexInfo->AcGunIndex > 0 &&
  152. pAcChargingInfo->SystemStatus == S_AUTHORIZING &&
  153. pAcChargingInfo->IsAvailable)
  154. ) {
  155. idleReq = true;
  156. }
  157. }
  158. if (pGunIndexInfo->AcGunIndex > 0 &&
  159. pSysInfo->CurGunSelectedByAc == DEFAULT_AC_INDEX &&
  160. pAcChargingInfo->SystemStatus == S_CHARGING) {
  161. stopReq = DEFAULT_AC_INDEX;
  162. }
  163. */
  164. if (strlen((char *)pSysConfig->UserId) <= 0) {
  165. return;
  166. }
  167. pDcChargingInfo = (struct ChargingInfoData *)GetDcChargingInfoData(pSysInfo->CurGunSelected);
  168. // Stop Charging For AC
  169. /*if (pGunIndexInfo->AcGunIndex > 0 &&
  170. stopReq == DEFAULT_AC_INDEX &&
  171. pSysInfo->CurGunSelectedByAc == DEFAULT_AC_INDEX) {
  172. log_info("ac stop charging ");
  173. log_info("index = %d, card number = %s, UserId = %s ",
  174. pSysInfo->CurGunSelectedByAc,
  175. pAcChargingInfo->StartUserId,
  176. pSysConfig->UserId);
  177. memset(value, 0, sizeof(value));
  178. memcpy(value,
  179. (uint8_t *)pAcChargingInfo->StartUserId,
  180. ARRAY_SIZE(pAcChargingInfo->StartUserId));
  181. if (strcmp((char *)pSysConfig->UserId, value) == EQUAL) {
  182. AcChargingTerminalProcess();
  183. }
  184. strcpy((char *)pSysConfig->UserId, "");
  185. } else if (stopReq < pSysConfig->TotalConnectorCount &&
  186. pDcChargingInfo->SystemStatus == S_CHARGING &&
  187. (pGunIndexInfo->AcGunIndex <= 0 ||
  188. (pGunIndexInfo->AcGunIndex > 0 &&
  189. pSysInfo->CurGunSelectedByAc == NO_DEFINE))
  190. ) {
  191. // Stop Charging
  192. if (RfidStopCharging())
  193. return;
  194. if (pGunIndexInfo->AcGunIndex > 0 &&
  195. pSysInfo->CurGunSelectedByAc == DEFAULT_AC_INDEX) {
  196. _authorizeIndex = pSysInfo->CurGunSelectedByAc;
  197. } else {
  198. _authorizeIndex = pSysInfo->CurGunSelected;
  199. }
  200. strcpy((char *)pSysConfig->UserId, "");
  201. return;
  202. } else if (idleReq) {
  203. if (pSysConfig->TotalConnectorCount > 1 &&
  204. stopReq != 255 &&
  205. pSysInfo->IsAlternatvieConf == YES) {
  206. idleReq = false;
  207. strcpy((char *)pSysConfig->UserId, "");
  208. } else if ((pGunIndexInfo->AcGunIndex > 0 &&
  209. pSysInfo->CurGunSelectedByAc == DEFAULT_AC_INDEX) ||
  210. pDcChargingInfo->SystemStatus == S_AUTHORIZING) {*/
  211. if ( (pSysInfo->SystemPage == _PAGE_AUTHORIZE ||
  212. pSysInfo->SystemPage == _PAGE_SENSING) &&
  213. pDcChargingInfo->SystemStatus == S_IDLE) {
  214. log_info("// LCM => Authorizing");
  215. confirmSelGun(pSysInfo->CurGunSelected);
  216. setSelGunWaitToAuthor(pSysInfo->CurGunSelected);
  217. StartSystemTimeoutDet(Timeout_Authorizing);
  218. AuthorizingStart();
  219. pDcChargingInfo->SystemStatus = S_AUTHORIZING;
  220. // LCM => Authorizing
  221. //pSysInfo->SystemPage = _PAGE_AUTHORIZE;
  222. // 進入確認卡號狀態
  223. } else {
  224. //strcpy((char *)pSysConfig->UserId, "");
  225. }
  226. return;
  227. }
  228. bool GetIsCardScan(void)
  229. {
  230. return isCardScan;
  231. }
  232. void SetIsCardScan(bool value)
  233. {
  234. isCardScan = value;
  235. }
  236. void AuthorizeToCharge()
  237. {
  238. struct SysConfigData *pSysConfig = (struct SysConfigData *)GetShmSysConfigData();
  239. struct SysInfoData *pSysInfo = (struct SysInfoData *)GetShmSysInfoData();
  240. // SelectGunInfo *ShmSelectGunInfo = (SelectGunInfo *)GetShmSelectGunInfo();
  241. // struct ChargingInfoData *pDcChargingInfo = (struct ChargingInfoData*)GetDcChargingInfoData(pSysInfo->CurGunSelected);;
  242. ShmDcCommonData = (DcCommonInfo *)GetShmDcCommonData();
  243. if(isAuthorizedComplete())
  244. {
  245. if (canStartCharging()) {
  246. DetectPluginStart();
  247. if (ShmDcCommonData->AuthPass_flag[pSysInfo->CurGunSelected] == TRUE &&
  248. ShmDcCommonData->TradeCancel == FALSE) {
  249. pSysInfo->SystemPage = _PAGE_PLUGIN;
  250. }
  251. } else {
  252. log_info("LCM => Authorize fail");
  253. ShmDcCommonData->TradeCancel = TRUE;
  254. ShmDcCommonData->PreAuth_Config = _CREDITCARD_CANCEL;
  255. ShmDcCommonData->PreAuth_Result = 0;
  256. pSysInfo->SystemPage = _PAGE_AUTHORIZE_FAIL;
  257. strcpy((char *)pSysConfig->UserId, "");
  258. }
  259. ClearAuthorizedFlag();
  260. }
  261. }
  262. void ScannerCardProcess(void)
  263. {
  264. //struct SysConfigData *pSysConfig = (struct SysConfigData *)GetShmSysConfigData();
  265. struct SysInfoData *pSysInfo = (struct SysInfoData *)GetShmSysInfoData();
  266. struct WARNING_CODE_INFO *pSysWarning = (struct WARNING_CODE_INFO *)GetShmSysWarningInfo();
  267. struct ChargingInfoData *pDcChargingInfo = NULL;
  268. pDcChargingInfo = (struct ChargingInfoData *)GetDcChargingInfoData(pSysInfo->CurGunSelected);
  269. if (!isDetectPlugin() && (pSysInfo->SystemPage == _PAGE_SENSING ||
  270. pSysInfo->SystemPage == _PAGE_AUTHORIZE ) &&
  271. pDcChargingInfo->SystemStatus == S_IDLE &&
  272. pSysWarning->Level != WARN_LV_ER ) {
  273. //setSelGunWaitToAuthor(pSysInfo->CurGunSelected);
  274. isCardScan = true;
  275. // 處理刷卡及驗證卡號的動作
  276. UserScanFunction();
  277. }
  278. if (pDcChargingInfo->SystemStatus == S_AUTHORIZING && pSysInfo->SystemPage == _PAGE_SENSING ) {
  279. AuthorizeToCharge();
  280. } else if (pSysInfo->SystemPage == _PAGE_AUTHORIZE_FAIL) {
  281. StartSystemTimeoutDet(Timeout_VerifyFail);
  282. isCardScan = false;
  283. } else {
  284. isCardScan = false;
  285. }
  286. }
  287. void WritePayResult(int result ,uint8_t gunIndex)
  288. {
  289. memcpy(&ShmDcCommonData->TransactionInfo[gunIndex], &LocalTransactionInfo, sizeof(RecordTransactionInfo));
  290. if (result == TRUE)
  291. ShmDcCommonData->TransactionInfo[gunIndex].DeductResult = _DEDUCT_COMPLETE_PASS;
  292. else
  293. ShmDcCommonData->TransactionInfo[gunIndex].DeductResult = _DEDUCT_COMPLETE_FAIL;
  294. log_info("Gun[%d] TransactionId:%d DeductResult:%d IsDonateInvoice:%d Amount:%f VemData:%s",
  295. gunIndex, ShmDcCommonData->TransactionInfo[gunIndex].TransactionId,
  296. ShmDcCommonData->TransactionInfo[gunIndex].DeductResult,
  297. ShmDcCommonData->TransactionInfo[gunIndex].IsDonateInvoice,
  298. ShmDcCommonData->TransactionInfo[gunIndex].Amount,
  299. ShmDcCommonData->TransactionInfo[gunIndex].pCreditCard.VemData);
  300. }
  301. void storePayResult(uint8_t gunIndex)
  302. {
  303. memset(&LocalTransactionInfo, 0, sizeof(RecordTransactionInfo));
  304. memcpy(&LocalTransactionInfo, &ShmDcCommonData->TransactionInfo[gunIndex] ,sizeof(RecordTransactionInfo));
  305. //LocalTransactionInfo.Amount = ShmDcCommonData->finalcost[gunIndex];
  306. }
  307. void PreAuthCompleteToCardReader(int fd,uint8_t gunIndex)
  308. {
  309. struct SysConfigData* pSysConfig = (struct SysConfigData*)GetShmSysConfigData();
  310. int result = 0;
  311. if (ShmDcCommonData->TransactionInfo[gunIndex].Amount > 0 && ShmDcCommonData->TransactionInfo[gunIndex].Amount < 1) {
  312. log_info("final cost less 1 : %f", ShmDcCommonData->TransactionInfo[gunIndex].Amount);
  313. ShmDcCommonData->TransactionInfo[gunIndex].Amount = 1;
  314. }
  315. storePayResult(gunIndex);
  316. result = CreditCardPreAuthComplete(fd,(int)ShmDcCommonData->TransactionInfo[gunIndex].Amount, &pSysConfig->ModelName[0],
  317. &ShmDcCommonData->TransactionInfo[gunIndex].pCreditCard.VemData[0],
  318. &ShmDcCommonData->TransactionInfo[gunIndex].pCreditCard);
  319. //sleep(10);
  320. if (result > 0 ) {
  321. log_info("Credit Card Spend Money:%.1f", LocalTransactionInfo.Amount);
  322. pSysInfo->SystemPage = _PAGE_COMPLETE;
  323. LocalTransactionInfo.DeductResult = _DEDUCT_COMPLETE_PASS;
  324. WritePayResult(TRUE,gunIndex);
  325. ShmDcCommonData->PayPass_flag[gunIndex] = TRUE;
  326. } else {
  327. log_info("PAYING FAIL");
  328. ShmDcCommonData->PayPass_flag[gunIndex] = FALSE;
  329. pSysInfo->SystemPage = _PAGE_PAYFAIL;
  330. LocalTransactionInfo.DeductResult = _DEDUCT_COMPLETE_FAIL;
  331. WritePayResult(FALSE,gunIndex);
  332. }
  333. ShmDcCommonData->TransactionInfo[gunIndex].IsUpload = FALSE;
  334. UpdateDeductInfoStatus(gunIndex, &ShmDcCommonData->TransactionInfo[gunIndex]);
  335. }
  336. int CreditCardCancelPreAuth(int fd, uint8_t gunIndex)
  337. {
  338. struct SysConfigData* pSysConfig = (struct SysConfigData*)GetShmSysConfigData();
  339. ShmDcCommonData->PreAuth_Result = CreditCardPreAuthCancel(fd, PREAUTHMONEY, &pSysConfig->ModelName[0],
  340. &ShmDcCommonData->TransactionInfo[gunIndex].pCreditCard.ApprovalNo[0],
  341. &ShmDcCommonData->TransactionInfo[gunIndex].pCreditCard.CardNo[0],
  342. &ShmDcCommonData->TransactionInfo[gunIndex].pCreditCard.VemData[0]);
  343. //sleep(10);
  344. if (ShmDcCommonData->PreAuth_Result >= 0) {
  345. strcpy((char*)pSysConfig->UserId, "");
  346. //ShmDcCommonData->PayFinish[gunIndex] = TRUE;
  347. log_info("Card Reader PreAuth Cancel Success");
  348. ShmDcCommonData->TransactionInfo[gunIndex].DeductResult = _DEDUCT_CANCEL;
  349. } else if (ShmDcCommonData->PreAuth_Result < 0) {
  350. log_info("Card Reader PreAuth Cancel Failure");
  351. ShmDcCommonData->TransactionInfo[gunIndex].DeductResult = _DEDUCT_PREAUTH;
  352. }
  353. ShmDcCommonData->TransactionInfo[gunIndex].IsUpload = FALSE;
  354. UpdateDeductInfoStatus(gunIndex, &ShmDcCommonData->TransactionInfo[gunIndex]);
  355. memset(&ShmDcCommonData->TransactionInfo[gunIndex], 0x00, sizeof(RecordTransactionInfo));
  356. ShmDcCommonData->PreAuth_Config = _CREDITCARD_IDLE;
  357. return ShmDcCommonData->PreAuth_Result;
  358. }
  359. void ReDeductProcess(int fd)
  360. {
  361. struct SysConfigData* pSysConfig = (struct SysConfigData*)GetShmSysConfigData();
  362. int j;
  363. int result;
  364. int rededuct_gunIndex[128];
  365. RecordTransactionInfo deductInfo[128];
  366. int rededuct_num = 0;
  367. rededuct_num = DB_GetMultiReDeductInfo(&rededuct_gunIndex[0], &deductInfo[0]);
  368. if (rededuct_num == 0) {
  369. //log_info("No Rededuct Information");
  370. } else {
  371. log_info("Rededuct Total Number:%d", rededuct_num);
  372. for (j = 0; j < rededuct_num; j++) {
  373. sleep(10);
  374. /*
  375. if (pSysInfo->SystemPage != _PAGE_IDLE && !ShmDcCommonData->Exe_ReDeduct) {
  376. ShmDcCommonData->RoutineReduct = FALSE;
  377. break;
  378. }
  379. */
  380. log_info("Start Rededuct item [%d]",j);
  381. if (deductInfo[j].isIntoCharge == FALSE ||
  382. (deductInfo[j].Energy == 0 && deductInfo[j].Amount == 0)) {
  383. // 未進入充電或度數等於零
  384. result = CreditCardPreAuthCancel(fd, PREAUTHMONEY, &pSysConfig->ModelName[0],
  385. &deductInfo[j].pCreditCard.ApprovalNo[0],
  386. &deductInfo[j].pCreditCard.CardNo[0],
  387. &deductInfo[j].pCreditCard.VemData[0]);
  388. sleep(10);
  389. if (result > 0) {
  390. deductInfo[j].DeductResult = _DEDUCT_CANCEL;
  391. log_info("Backgroud PreAuthCancel OK");
  392. }
  393. } else {
  394. // 度數大於零
  395. if (deductInfo[j].Amount == 0 && deductInfo[j].Energy > 0) {
  396. deductInfo[j].Amount = ceil(deductInfo[j].Energy * ShmDcCommonData->ChargingRate);
  397. if (deductInfo[j].Amount < 1)
  398. deductInfo[j].Amount = 1;
  399. log_info("Error Close Charging recount amount:%.1f",deductInfo[j].Amount);
  400. }
  401. result = CreditCardPreAuthComplete(fd, (int)deductInfo[j].Amount, &pSysConfig->ModelName[0],
  402. &deductInfo[j].pCreditCard.VemData[0],
  403. &ShmDcCommonData->TransactionInfo[0].pCreditCard);
  404. if (result > 0) {
  405. deductInfo[j].DeductResult = _DEDUCT_COMPLETE_PASS;
  406. log_info("Backgroud PreAuthComplete OK");
  407. } else if (result < 0) {
  408. deductInfo[j].DeductResult = _DEDUCT_COMPLETE_FAIL;
  409. log_info("Backgroud ID:%d Amount:%d VemData:%s PreAuthComplete fail",
  410. deductInfo[j].TransactionId,
  411. (int)deductInfo[j].Amount,
  412. deductInfo[j].pCreditCard.VemData);
  413. }
  414. }
  415. deductInfo[j].IsUpload = FALSE;
  416. deductInfo[j].RedeductTime++;
  417. UpdateDeductInfoStatus(rededuct_gunIndex[j], &deductInfo[j]);
  418. }
  419. }
  420. ShmDcCommonData->RoutineReduct = TRUE;
  421. }
  422. static int InitialRfidPort(void)
  423. {
  424. int fd = open(rfidPortName, O_RDWR);
  425. struct termios tios;
  426. struct AlarmCodeData *pAlarmCode = (struct AlarmCodeData *)GetShmAlarmCodeData();
  427. if (fd != FAIL) {
  428. ioctl (fd, TCGETS, &tios);
  429. tios.c_cflag = B115200 | CS8 | CLOCAL | CREAD;
  430. tios.c_lflag = 0;
  431. tios.c_iflag = 0;
  432. tios.c_oflag = 0;
  433. tios.c_cc[VMIN] = 0;
  434. tios.c_cc[VTIME] = (uint8_t) 1;
  435. tios.c_lflag = 0;
  436. tcflush(fd, TCIFLUSH);
  437. ioctl(fd, TCSETS, &tios);
  438. }
  439. if (fd < 0) {
  440. pAlarmCode->AlarmEvents.bits.RfidModuleCommFail = 1;
  441. }
  442. return fd;
  443. }
  444. void CreateRfidFork(void)
  445. {
  446. pid_t rfidRecPid;
  447. int rededuct_gunIndex[128];
  448. RecordTransactionInfo deductInfo[128];
  449. int rededuct_num = 0;
  450. int donate = 0;
  451. rfidRecPid = fork();
  452. int j = 0;
  453. int sel_gun = 0;
  454. if (rfidRecPid == 0) {
  455. //char localTime[128] = {0};
  456. struct timeb SeqEndTime;
  457. struct tm *tm;
  458. pSysInfo = (struct SysInfoData *)GetShmSysInfoData();
  459. int fd = -1;
  460. int isContinue = 1;
  461. //RFID rfid = {0};
  462. //RecordTransactionInfo deduct;
  463. fd = InitialRfidPort();
  464. struct SysConfigData *pSysConfig = (struct SysConfigData *)GetShmSysConfigData();
  465. ShmDcCommonData = (DcCommonInfo *)GetShmDcCommonData();
  466. ShmSelectGunInfo = (SelectGunInfo *)GetShmSelectGunInfo();
  467. struct ChargingInfoData *pDcChargingInfo = NULL;
  468. if (DeductDB_Open() != PASS) {
  469. isDeductDb_ready = false;
  470. } else {
  471. isDeductDb_ready = true;
  472. //InsertDeductInfo(0, &ShmDcCommonData->TransactionInfo);
  473. }
  474. int gunIndex;
  475. //int uploadIndex = 0;
  476. int ReAuthComplete_Index = 0;
  477. //log_info("RFID fork Child's PID is %d", getpid());
  478. int result;
  479. int is_idle = TRUE;
  480. while (isContinue) {
  481. result = 0;
  482. usleep(500000);
  483. ftime(&SeqEndTime);
  484. SeqEndTime.time = time(NULL);
  485. tm = localtime(&SeqEndTime.time);
  486. if (ShmDcCommonData->DebugFlag == TRUE ||
  487. ShmDcCommonData->is_RemoteStart[pSysInfo->CurGunSelected] == TRUE ||
  488. ShmDcCommonData->is_AutoStart[pSysInfo->CurGunSelected] == TRUE) {
  489. ShmDcCommonData->PreAuth_Config = _CREDITCARD_IDLE;
  490. ShmDcCommonData->PreAuth_Result = 0;
  491. }
  492. is_idle = TRUE;
  493. for (gunIndex = 0; gunIndex < pSysConfig->TotalConnectorCount; gunIndex++) {
  494. pDcChargingInfo = (struct ChargingInfoData *)GetDcChargingInfoData(gunIndex);
  495. if (pDcChargingInfo->SystemStatus != S_IDLE && pDcChargingInfo->SystemStatus != S_FAULT) {
  496. is_idle = FALSE;
  497. }
  498. if (ShmDcCommonData->StopCharge[gunIndex] == TRUE && pDcChargingInfo->Replug_flag == TRUE) {
  499. ShmDcCommonData->StopCharge[gunIndex] = FALSE;
  500. log_info("Not Into Charging cancel Trade");
  501. StopGunInfoTimeoutDet(gunIndex);
  502. ShmDcCommonData->TradeCancel = TRUE;
  503. pSysInfo->CurGunSelected = gunIndex;
  504. pSysInfo->SystemPage = _PAGE_SENSING;
  505. StartSystemTimeoutDet(Timeout_TradeCancel);
  506. CreditCardCancelPreAuth(fd, gunIndex);
  507. pSysInfo->SystemPage = _PAGE_PLUGOUT;
  508. StopSystemTimeoutDet();
  509. } else {
  510. if (ShmDcCommonData->StopCharge[gunIndex] == TRUE && ShmDcCommonData->finalcost_flag[gunIndex] &&
  511. (pSysInfo->SystemPage != _PAGE_AUTHORIZE && pSysInfo->SystemPage != _PAGE_SENSING)) {
  512. ShmDcCommonData->StopCharge[gunIndex] = FALSE;
  513. pSysInfo->CurGunSelected = gunIndex;
  514. if (pDcChargingInfo->Replug_flag == TRUE) {
  515. log_info("Not Into Charging cancel Trade");
  516. ShmDcCommonData->TradeCancel = TRUE;
  517. pSysInfo->SystemPage = _PAGE_SENSING;
  518. StartSystemTimeoutDet(Timeout_TradeCancel);
  519. } else
  520. pSysInfo->SystemPage = _PAGE_PAYING;
  521. StopGunInfoTimeoutDet(gunIndex); //Timeout_FinalCost
  522. // Remote Start of AutoStart ByPass Credit Card Reader
  523. if (ShmDcCommonData->DebugFlag == TRUE ||
  524. ShmDcCommonData->is_RemoteStart[gunIndex] == TRUE ||
  525. ShmDcCommonData->is_AutoStart[gunIndex] == TRUE) {
  526. pSysInfo->SystemPage = _PAGE_COMPLETE;
  527. ShmDcCommonData->PayPass_flag[gunIndex] = TRUE;
  528. continue;
  529. }
  530. // 實際扣款
  531. if (ShmDcCommonData->TransactionInfo[gunIndex].Amount < 1) {
  532. log_info("Final Cost less 1 , Cancel Trade!!");
  533. if (CreditCardCancelPreAuth(fd, gunIndex) > 0) {
  534. pSysInfo->SystemPage = _PAGE_COMPLETE;
  535. ShmDcCommonData->PayPass_flag[gunIndex] = TRUE;
  536. } else {
  537. pSysInfo->SystemPage = _PAGE_PAYFAIL;
  538. ShmDcCommonData->PayPass_flag[gunIndex] = FALSE;
  539. }
  540. } else {
  541. PreAuthCompleteToCardReader(fd, gunIndex);
  542. }
  543. }
  544. }
  545. } // for
  546. // 取消預授權
  547. if(ShmDcCommonData->PreAuth_Config == _CREDITCARD_CANCEL) {
  548. CreditCardCancelPreAuth(fd,pSysInfo->CurGunSelected);
  549. // 預授權
  550. } else if (ShmDcCommonData->PreAuth_Config == _CREDITCARD_PREAUTH /* && ShmDcCommonData->GetCardNo[pSysInfo->CurGunSelected]*/) {
  551. sel_gun = pSysInfo->CurGunSelected;
  552. donate = (int)ShmDcCommonData->TransactionInfo[sel_gun].IsDonateInvoice;
  553. memset(&ShmDcCommonData->TransactionInfo[sel_gun], 0x00, sizeof(RecordTransactionInfo));
  554. ShmDcCommonData->TransactionInfo[sel_gun].IsDonateInvoice = (unsigned char)donate;
  555. result = CreditCardPreAuth(fd, PREAUTHMONEY,&pSysConfig->ModelName[0], &ShmDcCommonData->TransactionInfo[sel_gun].pCreditCard);
  556. if (!ShmDcCommonData->TradeCancel)
  557. StopSystemTimeoutDet();
  558. if (ShmDcCommonData->TradeCancel == FALSE && result > 0) {
  559. pSysInfo->SystemPage = _PAGE_SENSING;
  560. }
  561. sleep(3);
  562. ShmDcCommonData->PreAuth_Result = result;
  563. //result = 1;
  564. if (result > 0 && strcmp(ShmDcCommonData->TransactionInfo[sel_gun].pCreditCard.CardNo,"") != 0 ) {
  565. ShmDcCommonData->AuthPass_flag[sel_gun] = TRUE;
  566. strncpy((char*)pSysConfig->UserId, (char *)ShmDcCommonData->TransactionInfo[sel_gun].pCreditCard.CardNo, 20);
  567. log_info("Authorize card:%s", pSysConfig->UserId);
  568. ShmDcCommonData->TransactionInfo[sel_gun].DeductResult = _DEDUCT_PREAUTH;
  569. ShmDcCommonData->TransactionInfo[sel_gun].IsUpload = FALSE;
  570. ShmDcCommonData->TransactionInfo[sel_gun].ConnectorID = ShmDcCommonData->ConnectorID[sel_gun];
  571. InsertDeductInfo(ShmDcCommonData->ConnectorID[sel_gun], &ShmDcCommonData->TransactionInfo[sel_gun]);
  572. log_info("PreAuth OK");
  573. } else if (result < 0) {
  574. if (ShmDcCommonData->TradeCancel == FALSE)
  575. pSysInfo->SystemPage = _PAGE_AUTHORIZE_FAIL;
  576. ShmDcCommonData->AuthPass_flag[sel_gun] = FALSE;
  577. memset(&ShmDcCommonData->TransactionInfo[sel_gun].pCreditCard, 0, sizeof(TransInfo));
  578. log_info("PreAuth Fail");
  579. sleep(7);
  580. }
  581. ShmDcCommonData->PreAuth_Config = _CREDITCARD_IDLE;
  582. }
  583. // 每30分鐘檢查補扣款
  584. if (tm->tm_min %30 == 0 && tm->tm_sec == 0) {
  585. ShmDcCommonData->RoutineReduct = FALSE;
  586. }
  587. if ((is_idle == TRUE &&
  588. pSysInfo->SystemPage == _PAGE_IDLE &&
  589. ShmDcCommonData->RoutineReduct == FALSE) || ShmDcCommonData->Exe_ReDeduct) {
  590. ShmDcCommonData->CreditCardUpload = TRUE;
  591. pSysInfo->SystemPage = _PAGE_PAYING;
  592. ReDeductProcess(fd);
  593. pSysInfo->SystemPage = _PAGE_IDLE;
  594. ShmDcCommonData->CreditCardUpload = FALSE;
  595. ShmDcCommonData->Exe_ReDeduct = 0;
  596. }
  597. // 每日晚上11點30分結帳
  598. if (is_idle == TRUE && pSysInfo->SystemPage == _PAGE_IDLE &&
  599. ((tm->tm_hour == 15 && tm->tm_min > 30 && ShmDcCommonData->RoutineSettlement == FALSE) ||
  600. ShmDcCommonData->UnionSettlement)) {
  601. StopSystemTimeoutDet();
  602. if (ShmDcCommonData->UnionSettlement)
  603. ShmDcCommonData->UnionSettlement = 0;
  604. else
  605. ShmDcCommonData->RoutineSettlement = TRUE;
  606. ShmDcCommonData->CreditCardUpload = TRUE;
  607. pSysInfo->SystemPage = _PAGE_PAYING;
  608. result = CreditCardUnionSettlement(fd, &pSysConfig->ModelName[0], &LocalTransactionInfo.pCreditCard);
  609. if (result > 0) {
  610. log_info("CreditCardUnionSettlement OK");
  611. }
  612. else
  613. log_info("CreditCardUnionSettlement FAIL");
  614. sleep(90);
  615. pSysInfo->SystemPage = _PAGE_IDLE;
  616. ShmDcCommonData->CreditCardUpload = FALSE;
  617. }
  618. if (tm->tm_hour == 16 && tm->tm_min == 0) {
  619. ShmDcCommonData->RoutineSettlement = FALSE;
  620. }
  621. /*
  622. // 刷卡判斷
  623. if (pSysConfig->OfflinePolicy == _OFFLINE_POLICY_NO_CHARGING ||
  624. !pSysConfig->isRFID) {
  625. continue;
  626. }
  627. if (getRequestCardSN(fd, 0, &rfid) == false) {
  628. continue;
  629. }
  630. //log_info("Get Card..-%s- ", pSysConfig->UserId);
  631. if (strlen((char *)pSysConfig->UserId) != 0) {
  632. continue;
  633. }
  634. if (pSysConfig->RfidCardNumEndian == RFID_ENDIAN_LITTLE) {
  635. switch (rfid.snType) {
  636. case RFID_SN_TYPE_6BYTE:
  637. sprintf((char *) pSysConfig->UserId,
  638. "%02X%02X%02X%02X%02X%02X",
  639. rfid.currentCard[0], rfid.currentCard[1],
  640. rfid.currentCard[2], rfid.currentCard[3],
  641. rfid.currentCard[4], rfid.currentCard[5]);
  642. break;
  643. case RFID_SN_TYPE_7BYTE:
  644. sprintf((char *) pSysConfig->UserId,
  645. "%02X%02X%02X%02X%02X%02X%02X",
  646. rfid.currentCard[0], rfid.currentCard[1],
  647. rfid.currentCard[2], rfid.currentCard[3],
  648. rfid.currentCard[4], rfid.currentCard[5],
  649. rfid.currentCard[6]);
  650. break;
  651. case RFID_SN_TYPE_10BYTE:
  652. sprintf((char *) pSysConfig->UserId,
  653. "%02X%02X%02X%02X%02X%02X%02X%02X%02X%02X",
  654. rfid.currentCard[0], rfid.currentCard[1],
  655. rfid.currentCard[2], rfid.currentCard[3],
  656. rfid.currentCard[4], rfid.currentCard[5],
  657. rfid.currentCard[6], rfid.currentCard[7],
  658. rfid.currentCard[8], rfid.currentCard[9]);
  659. break;
  660. case RFID_SN_TYPE_4BYTE:
  661. sprintf((char *) pSysConfig->UserId,
  662. "%02X%02X%02X%02X",
  663. rfid.currentCard[0], rfid.currentCard[1],
  664. rfid.currentCard[2], rfid.currentCard[3]);
  665. break;
  666. }
  667. } else if (pSysConfig->RfidCardNumEndian == RFID_ENDIAN_BIG) {
  668. switch (rfid.snType) {
  669. case RFID_SN_TYPE_6BYTE:
  670. sprintf((char *) pSysConfig->UserId,
  671. "%02X%02X%02X%02X%02X%02X",
  672. rfid.currentCard[5], rfid.currentCard[4],
  673. rfid.currentCard[3], rfid.currentCard[2],
  674. rfid.currentCard[1], rfid.currentCard[0]);
  675. break;
  676. case RFID_SN_TYPE_7BYTE:
  677. sprintf((char *) pSysConfig->UserId,
  678. "%02X%02X%02X%02X%02X%02X%02X",
  679. rfid.currentCard[6], rfid.currentCard[5],
  680. rfid.currentCard[4], rfid.currentCard[3],
  681. rfid.currentCard[2], rfid.currentCard[1],
  682. rfid.currentCard[0]);
  683. break;
  684. case RFID_SN_TYPE_10BYTE:
  685. sprintf((char *) pSysConfig->UserId,
  686. "%02X%02X%02X%02X%02X%02X%02X%02X%02X%02X",
  687. rfid.currentCard[9], rfid.currentCard[8],
  688. rfid.currentCard[7], rfid.currentCard[6],
  689. rfid.currentCard[5], rfid.currentCard[4],
  690. rfid.currentCard[3], rfid.currentCard[2],
  691. rfid.currentCard[1], rfid.currentCard[0]);
  692. break;
  693. case RFID_SN_TYPE_4BYTE:
  694. sprintf((char *) pSysConfig->UserId,
  695. "%02X%02X%02X%02X",
  696. rfid.currentCard[3], rfid.currentCard[2],
  697. rfid.currentCard[1], rfid.currentCard[0]);
  698. break;
  699. }
  700. }
  701. log_info("card number = %s", pSysConfig->UserId);
  702. */
  703. }
  704. }
  705. }