ContactlessFSM.cpp 42 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440
  1. #include "stdafx.h"
  2. #include "ContactlessFSM.h"
  3. #include "EventCode.h"
  4. #include "GetDevInfoHelper.h"
  5. #include "ContactlessCard_msg_g.h"
  6. #include "ModuleMix.h"
  7. #include "ContactlessCard_UserErrorCode.h"
  8. #include "CommDevEntityErrorCode.h"
  9. #include <map>
  10. //#include "RVCComm.h"
  11. #include "publicFunExport.h"
  12. #include "json/json.h"
  13. const int GET_DEV_STATUS_COUNT = 3;
  14. const int MAX_RESET_TIMES_PERIOD = 1000;//oiltest configure to ini file?
  15. const int MAX_RESET_TIMEROUT = 5000;
  16. const int WAIT_TRY_NUM = 120;
  17. const int WAIT_INTERVAL = 500;
  18. const int ACCEPT_TRY_INTERVAL = 500;
  19. const int ACCEPT_TRY_NUM = 110; // 500*110=55 seconds
  20. const int READ_TRY_NUM = 1;//oiltest
  21. const int INIT_TRY_NUM = 3;
  22. class CContactlessCardEntity;
  23. void CContactlessCardFSM::s0_on_entry()
  24. {
  25. LOG_FUNCTION();
  26. m_eDevState = DEVICE_STATUS_NOT_READY;
  27. FSMEvent *e = new FSMEvent(USER_EVT_INIT);
  28. PostEventFIFO(e);
  29. }
  30. void CContactlessCardFSM::s0_on_exit()
  31. {
  32. LOG_FUNCTION();
  33. }
  34. unsigned int CContactlessCardFSM::s0_on_event(FSMEvent* e)
  35. {
  36. LOG_FUNCTION();
  37. if (e->iEvt == USER_EVT_INIT) {
  38. InitTask* task = new InitTask(this);
  39. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  40. e->SetHandled();
  41. return 0;
  42. }else if (e->iEvt == USER_EVT_QUIT) {
  43. e->SetHandled();
  44. return 0;
  45. }
  46. return 0;
  47. }
  48. void CContactlessCardFSM::s1_on_entry()
  49. {
  50. LOG_FUNCTION();
  51. }
  52. void CContactlessCardFSM::s1_on_exit()
  53. {
  54. LOG_FUNCTION();
  55. }
  56. unsigned int CContactlessCardFSM::s1_on_event(FSMEvent* event)
  57. {
  58. LOG_FUNCTION();
  59. if (event->iEvt == USER_EVT_INITFINISHED) {
  60. event->SetHandled();
  61. int err = event->param1;
  62. if (err == 0) {
  63. return 0;
  64. } else {
  65. return 1;
  66. }
  67. }else if (event->iEvt == USER_EVT_QUIT) {
  68. event->SetHandled();
  69. return 0;
  70. }
  71. return 0;
  72. }
  73. //Idle
  74. void CContactlessCardFSM::s2_on_entry()
  75. {
  76. LOG_FUNCTION();
  77. GetEntityBase()->GetFunction()->SetUserDefineState(USER_CONTACTLESSCARD_IDLE);
  78. m_eDevState = DEVICE_STATUS_NORMAL;
  79. m_resetTimes = 0;
  80. m_testResult = Error_Succeed;
  81. ToLogWarnInfoAboutTermCustom();
  82. }
  83. void CContactlessCardFSM::s2_on_exit()
  84. {
  85. LOG_FUNCTION();
  86. }
  87. unsigned int CContactlessCardFSM::s2_on_event(FSMEvent* pEvt)
  88. {
  89. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("s2 evt(%d",pEvt->iEvt);
  90. int ret = 0;
  91. switch(pEvt->iEvt)
  92. {
  93. case USER_EVT_ACCEPT:
  94. {
  95. CardAcceptEvent *cae = dynamic_cast<CardAcceptEvent*>(pEvt);
  96. m_bCancelAccept = false;
  97. AcceptTask* task = new AcceptTask(this);
  98. task->ctx = cae->ctx;
  99. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  100. pEvt->SetHandled();
  101. }
  102. break;
  103. case USER_EVT_QUERY_CARD_INFO:
  104. {
  105. pEvt->SetHandled();
  106. QueryCardInfoEvent *pQCIE = dynamic_cast<QueryCardInfoEvent*>(pEvt);
  107. QueryCardInfoTask* task = new QueryCardInfoTask(this);
  108. task->ctx = pQCIE->ctx;
  109. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  110. return 0;
  111. }
  112. case USER_EVT_EJECT:
  113. {
  114. CardEjectEvent *cee;
  115. if (pEvt->iEvt == USER_EVT_EJECT)
  116. cee = dynamic_cast<CardEjectEvent*>(pEvt);
  117. EjectTask *task= new EjectTask(this);
  118. if (pEvt->iEvt == USER_EVT_EJECT)
  119. task->ctx = cee->ctx;
  120. else
  121. task->ctx = NULL;
  122. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  123. pEvt->SetHandled();
  124. return 0;
  125. }
  126. case USER_EVT_EXIT:
  127. m_bExit = true;
  128. pEvt->SetHandled();
  129. break;
  130. case USER_EVT_QUIT:
  131. pEvt->SetHandled();
  132. break;
  133. default:
  134. break;
  135. }
  136. return ret;
  137. }
  138. //accepting
  139. void CContactlessCardFSM::s3_on_entry()
  140. {
  141. LOG_FUNCTION();
  142. }
  143. void CContactlessCardFSM::s3_on_exit()
  144. {
  145. LOG_FUNCTION();
  146. }
  147. unsigned int CContactlessCardFSM::s3_on_event(FSMEvent* pEvt)
  148. {
  149. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("s3 evt (%d)(%d)",pEvt->iEvt,pEvt->param1);
  150. int ret = 0;
  151. switch(pEvt->iEvt)
  152. {
  153. case USER_EVT_ACCEPTFINISHED:
  154. {
  155. pEvt->SetHandled();
  156. switch(pEvt->param1)
  157. {
  158. case 0:
  159. case 1:
  160. case 2:
  161. case 3:
  162. case 4:
  163. ret = pEvt->param1;
  164. break;
  165. default:
  166. ret = 1;
  167. break;
  168. }
  169. }
  170. break;
  171. case USER_EVT_ACCEPT_CANCEL:
  172. m_bCancelAccept = true;
  173. pEvt->SetHandled();
  174. ret = 3;
  175. break;
  176. case USER_EVT_QUERY_CARD_INFO:
  177. {
  178. pEvt->SetHandled();
  179. QueryCardInfoEvent *pQCIE = dynamic_cast<QueryCardInfoEvent*>(pEvt);
  180. QueryCardInfoTask* task = new QueryCardInfoTask(this);
  181. task->ctx = pQCIE->ctx;
  182. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  183. return 0;
  184. }
  185. case USER_EVT_EXIT:
  186. m_bExit = true;
  187. pEvt->SetHandled();
  188. break;
  189. case USER_EVT_QUIT:
  190. pEvt->SetHandled();
  191. break;
  192. default:
  193. break;
  194. }
  195. return ret;
  196. }
  197. //Hold
  198. void CContactlessCardFSM::s4_on_entry()
  199. {
  200. LOG_FUNCTION();
  201. GetEntityBase()->GetFunction()->SetUserDefineState(USER_CONTACTLESSCARD_HOLD);
  202. }
  203. void CContactlessCardFSM::s4_on_exit()
  204. {
  205. LOG_FUNCTION();
  206. }
  207. unsigned int CContactlessCardFSM::s4_on_event(FSMEvent* pEvt)
  208. {
  209. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("s4 evt(%d,%d)",pEvt->iEvt,pEvt->param1);
  210. switch(pEvt->iEvt){
  211. case USER_EVT_ACCEPT:
  212. {
  213. CardAcceptEvent *cae = dynamic_cast<CardAcceptEvent*>(pEvt);
  214. m_bCancelAccept = false;
  215. AcceptTask* task = new AcceptTask(this);
  216. task->ctx = cae->ctx;
  217. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  218. pEvt->SetHandled();
  219. }
  220. break;
  221. case USER_EVT_PREONLINE:
  222. {
  223. PreOnlineEvent* poe = dynamic_cast<PreOnlineEvent*>(pEvt);
  224. PreOnlineTask* task = new PreOnlineTask(this);
  225. task->ctx = poe->ctx;
  226. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  227. pEvt->SetHandled();
  228. return 0;
  229. }
  230. case USER_EVT_POSTONLINE:
  231. {
  232. PostOnlineEvent* poe = dynamic_cast<PostOnlineEvent*>(pEvt);
  233. PostOnlineTask* task = new PostOnlineTask(this);
  234. task->ctx = poe->ctx;
  235. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  236. pEvt->SetHandled();
  237. return 0;
  238. }
  239. case USER_EVT_EXIT:
  240. case USER_EVT_EJECT:
  241. //case USER_EVT_ACCEPT:
  242. {
  243. pEvt->SetHandled();
  244. //if (pEvt->iEvt == USER_EVT_ACCEPT)
  245. //{
  246. // CardAcceptEvent *pCAE = dynamic_cast<CardAcceptEvent*>(pEvt);
  247. // pCAE->ctx->Answer(Error_Duplication);
  248. // return 0;
  249. //}
  250. //if ((pEvt->iEvt == USER_EVT_EXIT) && m_bIssued)
  251. //{
  252. // return 1;
  253. //}
  254. CardEjectEvent *cee;
  255. if (pEvt->iEvt == USER_EVT_EJECT)
  256. cee = dynamic_cast<CardEjectEvent*>(pEvt);
  257. EjectTask *task= new EjectTask(this);
  258. if (pEvt->iEvt == USER_EVT_EJECT)
  259. task->ctx = cee->ctx;
  260. else
  261. task->ctx = NULL;
  262. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  263. return 0;
  264. }
  265. case USER_EVT_QUERY_CARD_INFO:
  266. {
  267. pEvt->SetHandled();
  268. QueryCardInfoEvent *pQCIE = dynamic_cast<QueryCardInfoEvent*>(pEvt);
  269. QueryCardInfoTask* task = new QueryCardInfoTask(this);
  270. task->ctx = pQCIE->ctx;
  271. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  272. return 0;
  273. }
  274. case USER_EVT_QUERY_CARD_INFO_FINISHED:
  275. {
  276. pEvt->SetHandled();
  277. if (pEvt->param1 == 0)
  278. return 0;
  279. else
  280. return 1;
  281. }
  282. case USER_EVT_QUIT:
  283. {
  284. pEvt->SetHandled();
  285. return 0;
  286. }
  287. case USER_EVT_ACCEPT_CANCEL:
  288. m_bCancelAccept = true;
  289. pEvt->SetHandled();
  290. default:
  291. break;
  292. }
  293. return 0;
  294. }
  295. //Reading
  296. void CContactlessCardFSM::s5_on_entry()
  297. {
  298. LOG_FUNCTION();
  299. GetEntityBase()->GetFunction()->SetUserDefineState(USER_CONTACTLESSCARD_READING);
  300. }
  301. void CContactlessCardFSM::s5_on_exit()
  302. {
  303. LOG_FUNCTION();
  304. }
  305. unsigned int CContactlessCardFSM::s5_on_event(FSMEvent* pEvt)
  306. {
  307. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("s5 event(%d)",pEvt->iEvt);
  308. switch(pEvt->iEvt)
  309. {
  310. case USER_EVT_EXIT:
  311. {
  312. //CardEjectEvent *cee = dynamic_cast<CardEjectEvent*>(pEvt);
  313. EjectTask *task= new EjectTask(this);
  314. task->ctx = NULL;
  315. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  316. pEvt->SetHandled();
  317. return 0;
  318. }
  319. break;
  320. case USER_EVT_QUIT:
  321. {
  322. pEvt->SetHandled();
  323. return 0;
  324. }
  325. default:
  326. break;
  327. }
  328. return 0;
  329. }
  330. //Ejecting
  331. void CContactlessCardFSM::s6_on_entry()
  332. {
  333. LOG_FUNCTION();
  334. }
  335. void CContactlessCardFSM::s6_on_exit()
  336. {
  337. LOG_FUNCTION();
  338. }
  339. unsigned int CContactlessCardFSM::s6_on_event(FSMEvent* pEvt)
  340. {
  341. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("s6 evt(%d,%d)",pEvt->iEvt,pEvt->param1);
  342. int ret = 0;
  343. switch(pEvt->iEvt)
  344. {
  345. case USER_EVT_EJECTFINISHED:
  346. pEvt->SetHandled();
  347. ret = pEvt->param1;
  348. break;
  349. case USER_EVT_QUIT:
  350. case USER_EVT_EXIT:
  351. pEvt->SetHandled();
  352. break;
  353. default:
  354. break;
  355. }
  356. return ret;
  357. }
  358. void CContactlessCardFSM::s7_on_entry()
  359. {
  360. LOG_FUNCTION();
  361. GetEntityBase()->GetFunction()->SetUserDefineState(USER_CONTACTLESSCARD_WAITFETCHING);
  362. WaitFetchingTask* task = new WaitFetchingTask(this);
  363. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  364. }
  365. void CContactlessCardFSM::s7_on_exit()
  366. {
  367. LOG_FUNCTION();
  368. }
  369. unsigned int CContactlessCardFSM::s7_on_event(FSMEvent* pEvt)
  370. {
  371. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("s7 evt(%d)",pEvt->iEvt);
  372. switch(pEvt->iEvt)
  373. {
  374. case USER_EVT_WAITFINISHED:
  375. {
  376. pEvt->SetHandled();
  377. if (pEvt->param1 == 0) {
  378. FetchCard evt;
  379. evt.status = 0;
  380. SpSendBroadcast(m_pEntity->GetFunction(),SP_MSG_OF(FetchCard),SP_MSG_SIG_OF(FetchCard),evt);
  381. LogEvent(Severity_Middle,LOG_EVT_CONTACTLESS_CARD_OP,"CardIssuer op.");
  382. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("客户取走卡片msg发送");
  383. return 0;
  384. } else if (pEvt->param1 == 1) {
  385. //FetchCard evt;
  386. //evt.status = 1;
  387. //SpSendBroadcast(m_pEntity->GetFunction(),SP_MSG_OF(FetchCard),SP_MSG_SIG_OF(FetchCard),evt);
  388. //Dbg("取卡时设备故障");
  389. //return 1;
  390. } else {
  391. FetchCard evt;
  392. evt.status = 2;
  393. SpSendBroadcast(m_pEntity->GetFunction(),SP_MSG_OF(FetchCard),SP_MSG_SIG_OF(FetchCard),evt);
  394. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("客户未取卡超时msg发送");
  395. LogWarn(Severity_Middle, Error_NotInit, ContactlessCard_UserErrorCode_FORGET_FETCH, "Customer forget fetch card.");
  396. return 2;
  397. }
  398. }
  399. case USER_EVT_QUERY_CARD_INFO:
  400. {
  401. pEvt->SetHandled();
  402. QueryCardInfoEvent *pQCIE = dynamic_cast<QueryCardInfoEvent*>(pEvt);
  403. QueryCardInfoTask* task = new QueryCardInfoTask(this);
  404. task->ctx = pQCIE->ctx;
  405. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  406. return 0;
  407. }
  408. case USER_EVT_QUIT:
  409. {
  410. pEvt->SetHandled();
  411. return 0;
  412. }
  413. default:
  414. break;
  415. }
  416. return 0;
  417. }
  418. //capture
  419. void CContactlessCardFSM::s8_on_entry()
  420. {
  421. LOG_FUNCTION();
  422. }
  423. void CContactlessCardFSM::s8_on_exit()
  424. {
  425. LOG_FUNCTION();
  426. }
  427. unsigned int CContactlessCardFSM::s8_on_event(FSMEvent* pEvt)
  428. {
  429. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("s8 evt(%d)",pEvt->iEvt);
  430. if (pEvt->iEvt == USER_EVT_CAPTUREFINISHED){
  431. pEvt->SetHandled();
  432. int err = pEvt->param1;
  433. if (err == 0)
  434. return 0;
  435. else
  436. return 1;
  437. }else if (pEvt->iEvt == USER_EVT_QUIT) {
  438. pEvt->SetHandled();
  439. return 0;
  440. }
  441. return 0;
  442. }
  443. void CContactlessCardFSM::s9_on_entry()
  444. {
  445. LOG_FUNCTION();
  446. GetEntityBase()->GetFunction()->SetUserDefineState(USER_CONTACTLESSCARD_FAILED);
  447. m_eDevState = DEVICE_STATUS_FAULT;
  448. FSMEvent *e = new FSMEvent(USER_EVT_RESET);
  449. PostEventFIFO(e);
  450. }
  451. void CContactlessCardFSM::s9_on_exit()
  452. {
  453. LOG_FUNCTION();
  454. }
  455. unsigned int CContactlessCardFSM::s9_on_event(FSMEvent* pEvt)
  456. {
  457. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("s9 evt(%d)(%d)",pEvt->iEvt, pEvt->param1);
  458. switch(pEvt->iEvt)
  459. {
  460. case USER_EVT_RESET:
  461. {
  462. pEvt->SetHandled();
  463. m_resetTimes++;
  464. if (m_resetTimes > MAX_RESET_TIMES_PERIOD)
  465. {
  466. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("restart tried %d times,give up",m_resetTimes);
  467. m_testResult = Error_InvalidState;
  468. LogWarn(Severity_Middle,Error_Unexpect, ContactlessCard_UserErrorCode_Reset_Failed,"reset failed more times");
  469. return 0;
  470. }
  471. ResetDeviceEvent* rde = dynamic_cast<ResetDeviceEvent*>(pEvt);
  472. ResetTask* task = new ResetTask(this);
  473. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  474. return 0;
  475. }
  476. break;
  477. case USER_EVT_RESETFINISHED:
  478. {
  479. ResetFinishedEvent *rfe = dynamic_cast<ResetFinishedEvent*>(pEvt);
  480. return rfe->param1;
  481. }
  482. case USER_EVT_QUERY_CARD_INFO:
  483. {
  484. pEvt->SetHandled();
  485. QueryCardInfoEvent *pQCIE = dynamic_cast<QueryCardInfoEvent*>(pEvt);
  486. QueryCardInfoTask* task = new QueryCardInfoTask(this);
  487. task->ctx = pQCIE->ctx;
  488. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  489. return 0;
  490. }
  491. case USER_EVT_QUIT:
  492. pEvt->SetHandled();
  493. return 0;
  494. case USER_EVT_ACCEPT_CANCEL:
  495. m_bCancelAccept = true;
  496. pEvt->SetHandled();
  497. break;
  498. default:
  499. break;
  500. }
  501. return 0;
  502. }
  503. ErrorCodeEnum CContactlessCardFSM::OnInit()
  504. {
  505. LOG_FUNCTION();
  506. auto pEntity = GET_DEV_ENTITY_BASE_POINTER();
  507. pEntity->LoadVendorLibName();
  508. FulfillAdapterInfoFrom(pEntity->vendorLibInfo);
  509. m_pCardProcess = new CCardProcess();
  510. if (m_pCardProcess == NULL)//almost no use...
  511. {
  512. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("create card process failed.");
  513. return Error_Resource;
  514. }
  515. CSystemStaticInfo sysInfo;
  516. m_csMachineType = "";
  517. GetEntityBase()->GetFunction()->GetSystemStaticInfo(sysInfo);
  518. m_csMachineType = sysInfo.strMachineType;
  519. ErrorCodeEnum errCode = Load();
  520. if (errCode != Error_Succeed)
  521. {
  522. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Load failed(%d).",errCode);
  523. return errCode;
  524. }
  525. devStatus.eMediaPos = CI_MEDIA_NOTPRESENT;
  526. return Error_Succeed;
  527. }
  528. ErrorCodeEnum CContactlessCardFSM::OnExit()
  529. {
  530. LOG_FUNCTION();
  531. ErrorCodeEnum eExit;
  532. long l_beginTime, l_endTime;
  533. if (m_hDevHelper != nullptr)
  534. {
  535. l_beginTime = GetTickCount();
  536. eExit = m_hDevHelper->GetDevStatus(devStatus);
  537. l_endTime = GetTickCount();
  538. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("OnExit::GetDevStatus eMedia:%d,l_beginTime:%d, l_endTime:%d, eErr:%d", devStatus.eMediaPos, l_beginTime, l_endTime, eExit);
  539. if (eExit == Error_Succeed)
  540. {
  541. if (devStatus.eMediaPos == CI_MEDIA_PRESENT){
  542. }
  543. }
  544. eExit = m_hDevHelper->DevClose();
  545. if (eExit == Error_Succeed)
  546. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("读卡器关闭成功");
  547. else{
  548. SetErrPackage("OnExit::DevClose", m_csDevNo, eExit, MEC_DEVAPI_RF_DevClose);
  549. AlarmDEC();
  550. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("读卡器关闭失败(%d)",eExit);
  551. }
  552. }
  553. FSMImpl<CContactlessCardFSM>::OnExit();
  554. return Error_Succeed;
  555. }
  556. ErrorCodeEnum CContactlessCardFSM::Load()
  557. {
  558. LOG_FUNCTION();
  559. ErrorCodeEnum hr;
  560. long l_beginTime, l_endTime;
  561. int initTries = 0;
  562. ErrorCodeEnum eErrDev = Error_Unexpect;
  563. LogWarn(Severity_Low, Error_Unexpect, ContactlessCard_UserErrorCode_RootInfo, m_adapterInfo.adapterFilePath.GetData());
  564. ToLogRootINIInfoOnce();
  565. CSmartPointer<IEntityFunction> spEntityFunction = GetEntityBase()->GetFunction();
  566. CSmartPointer<IConfigInfo> spConfig;
  567. CSimpleStringA csBinPath,csBackslash("\\");
  568. ErrorCodeEnum eErrPath = GetEntityBase()->GetFunction()->GetPath("Bin", csBinPath);
  569. if (eErrPath != Error_Succeed)
  570. {
  571. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Load, GetBasePath failed (%d).",eErrPath);
  572. return Error_Param;
  573. }
  574. if (Error_Succeed != m_hDevHelper.LoadUp(m_adapterInfo.adapterFilePath)) {
  575. return Error_DevLoadFileFailed;
  576. }
  577. do{
  578. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("open card issuer, port:%d, baudRate:%d", m_adapterInfo.GetPortInt(), m_adapterInfo.GetBaudrateInt());
  579. l_beginTime = GetTickCount();
  580. hr = m_hDevHelper->DevOpen(m_adapterInfo.GetPortInt(), m_adapterInfo.GetBaudrateInt());
  581. l_endTime = GetTickCount();
  582. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("port:%d, baudRate:%d,l_beginTime:%d, l_endTime:%d, hr:%d",
  583. m_adapterInfo.GetPortInt(), m_adapterInfo.GetBaudrateInt(), l_beginTime, l_endTime, hr);
  584. if (hr == Error_Succeed)
  585. {
  586. m_bOpened = true;
  587. ZeroMemory(m_devCatInfo.szModel, sizeof(m_devCatInfo.szModel));
  588. ZeroMemory(m_devCatInfo.szType, sizeof(m_devCatInfo.szType));
  589. ZeroMemory(m_devCatInfo.szVendor, sizeof(m_devCatInfo.szVendor));
  590. l_beginTime = GetTickCount();
  591. eErrDev = m_hDevHelper->GetDevCategory(m_devCatInfo);
  592. l_endTime = GetTickCount();
  593. if(eErrDev == Error_Succeed)
  594. {
  595. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetDevCategory szVendor:%s, szType:%s, szModel:%s,l_beginTime:%d, l_endTime:%d, eErrDev:%d",
  596. m_devCatInfo.szVendor, m_devCatInfo.szType, m_devCatInfo.szModel, l_beginTime, l_endTime, eErrDev);
  597. m_adapterInfo.FulfillCategoryInfo(m_devCatInfo);
  598. }
  599. else
  600. {
  601. SetErrPackage("Load::GetDevCategory", m_csDevNo, hr, MEC_DEVAPI_RF_GetDevCategory);
  602. AlarmDEC();
  603. return Error_DevCommFailed;
  604. }
  605. #ifdef RVC_OS_WIN
  606. CSimpleStringA csCMBPrint("CMBPrint.dll");
  607. csCMBPrint = csBinPath + csBackslash + csCMBPrint;
  608. DbgInfo(CSimpleStringA::Format("cmbpath %s", (LPCTSTR)csCMBPrint));
  609. HMODULE hr = LoadLibraryA(csCMBPrint);
  610. if (hr == NULL)
  611. {
  612. DbgWarn(CSimpleStringA::Format("Load CMBPrint failed(%d).", hr));
  613. return Error_DevLoadFileFailed;
  614. }
  615. if ((cmdDecodeMag2 = (lpCMBdecodeMag2)GetProcAddress(hr, "CMBdecodeMag2")) == NULL)
  616. {
  617. DbgWarn("Get Mag2 address failed.");
  618. return Error_DevLoadFileFailed;
  619. }
  620. if ((cmdDecodeEx = (lpCMBdecodeEx)GetProcAddress(hr, "CMBdecodeEx")) == NULL)
  621. {
  622. DbgWarn("Get Mag23Ex address failed.");
  623. return Error_DevLoadFileFailed;
  624. }
  625. initTries = 0;
  626. break;
  627. #else
  628. CSimpleStringA csCMBPrint("libCMBPrint.so");
  629. csCMBPrint = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",
  630. csBinPath.GetData(), csCMBPrint.GetData());
  631. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("cmbpath %s", csCMBPrint.GetData());
  632. toolkit_lib_t dlOpen;
  633. int res = toolkit_dlopen(csCMBPrint, &dlOpen);
  634. if (res != 0) {
  635. DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("Load CMBPrint failed with error %s.", toolkit_dlerror(&dlOpen));
  636. return Error_DevLoadFileFailed;
  637. }
  638. if ((res = toolkit_dlsym(&dlOpen, "CMBdecodeMag2", (void**)&cmdDecodeMag2)) != 0) {
  639. DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("Get Mag2 address failed.");
  640. return Error_DevLoadFileFailed;
  641. }
  642. if ((res = toolkit_dlsym(&dlOpen, "CMBdecodeEx", (void**)&cmdDecodeEx)) != 0) {
  643. DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("Get Mag23Ex address failed.");
  644. return Error_DevLoadFileFailed;
  645. }
  646. initTries = 0;
  647. break;
  648. #endif // RVC_OS_WIN
  649. } else {
  650. WORD devErrCode = eErrDev;
  651. CSimpleStringA errMsg = "";
  652. GetAndSplitDevErrInfo(errMsg, devErrCode, "DevOpen");
  653. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("ContactlessCard DevOpen failed (%s)", SpStrError(eErrDev));
  654. initTries++;
  655. }
  656. } while (initTries < INIT_TRY_NUM);
  657. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("inittries[%d]", initTries);
  658. if (initTries != 0)
  659. {
  660. if (m_bOpened) {
  661. m_hDevHelper->DevClose();
  662. m_bOpened = false;
  663. }
  664. LogWarn(Severity_Middle, Error_Unexpect, ContactlessCard_UserErrorCode_DevOpen_Failed, "非接读卡器打开失败");
  665. return Error_DevCommFailed;
  666. }
  667. else
  668. {
  669. eErrDev = spEntityFunction->OpenConfig(Config_Run, spConfig);
  670. if (eErrDev != Error_Succeed) {
  671. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Load, open run cfg file failed!");
  672. return eErrDev;
  673. }
  674. int ret = 0,isIssue = 0;
  675. if ((spConfig->ReadConfigValueInt("RunInfo","CardRemains",m_CardRemains) == Error_Succeed)
  676. && (spConfig->ReadConfigValueInt("RunInfo","CardIssued",m_CardIssued) == Error_Succeed)
  677. && (spConfig->ReadConfigValueInt("RunInfo","CardCaptured",m_CardCaptured) == Error_Succeed)
  678. && (spConfig->ReadConfigValueInt("RunInfo","IsIssue",isIssue) == Error_Succeed)
  679. && (spConfig->ReadConfigValueInt("RunInfo","CardMixed",m_CardMixed) == Error_Succeed)
  680. && (spConfig->ReadConfigValueInt("RunInfo","CardInit",m_CardInit) == Error_Succeed)
  681. && (spConfig->ReadConfigValueInt("RunInfo","CardPercent",m_CardPercent) == Error_Succeed))
  682. {
  683. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("CardRemains:%d, m_CardIssued:%d, CardCaptured:%d, isIssue:%d, CardMixed:%d, CardInit:%d",
  684. m_CardRemains, m_CardIssued, m_CardCaptured, isIssue, m_CardMixed, m_CardInit);
  685. m_bIssued = !!(isIssue);
  686. //ret = UnAcceptCard();
  687. }
  688. else
  689. return Error_IO;
  690. if (ret == 0)
  691. {
  692. m_devInit = true;
  693. LogWarn(Severity_Low, Error_Unexpect, ContactlessCard_UserErrorCode_DevOpen_Success, "非接读卡器打开成功");
  694. return Error_Succeed;
  695. }
  696. else{
  697. LogWarn(Severity_Middle, Error_Unexpect, ContactlessCard_UserErrorCode_DevOpen_Failed, "非接读卡器打开失败1");
  698. return Error_Unexpect;
  699. }
  700. }
  701. }
  702. int CContactlessCardFSM::Initial()
  703. {
  704. return 0;
  705. }
  706. bool CContactlessCardFSM::GetDevStatus(bool bPrint)
  707. {
  708. int getDevInfoCount = 0;
  709. long l_beginTime, l_endTime;
  710. ErrorCodeEnum eErr;
  711. do{
  712. l_beginTime = GetTickCount();
  713. eErr = m_hDevHelper->GetDevStatus(devStatus);
  714. l_endTime = GetTickCount();
  715. if (bPrint)
  716. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetDevStatus eMedia:%d,l_beginTime:%d, l_endTime:%d, eErr:%d", devStatus.eMediaPos, l_beginTime, l_endTime, eErr);
  717. if (Error_Succeed == eErr)
  718. return true;
  719. else
  720. {
  721. DevErrorInfo devErrInfo;
  722. m_hDevHelper->GetLastErr(devErrInfo);
  723. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("GetDevStatus, errMsg:%s",devErrInfo.szErrMsg);
  724. getDevInfoCount++;
  725. Sleep(3000);
  726. }
  727. } while (getDevInfoCount < GET_DEV_STATUS_COUNT);
  728. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("getdevstatus to reset");
  729. eErr = m_hDevHelper->Reset();
  730. Sleep(MAX_RESET_TIMEROUT);
  731. if (eErr == Error_Succeed)
  732. {
  733. eErr = m_hDevHelper->GetDevStatus(devStatus);
  734. if (eErr == Error_Succeed && devStatus.eMediaPos == CI_MEDIA_PRESENT)
  735. {
  736. }
  737. }
  738. return false;
  739. }
  740. int CContactlessCardFSM::Reset()
  741. {
  742. LOG_FUNCTION();
  743. ErrorCodeEnum eErr;
  744. long l_beginTime, l_endTime;
  745. eErr = m_hDevHelper->Reset();
  746. if (eErr == Error_Succeed)
  747. {
  748. l_beginTime = GetTickCount();
  749. eErr = m_hDevHelper->GetDevStatus(devStatus);
  750. l_endTime = GetTickCount();
  751. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Reset, GetDevStatus eMedia:%d,l_beginTime:%d, l_endTime:%d, eErr:%d", devStatus.eMediaPos, l_beginTime, l_endTime, eErr);
  752. if (Error_Succeed == eErr)
  753. {
  754. return 0;
  755. }
  756. else{
  757. SetErrPackage("Reset::GetDevStatus", m_csDevNo, eErr, MEC_DEVAPI_RF_GetDevStatus);
  758. AlarmDEC();
  759. return 2;
  760. }
  761. }
  762. else
  763. {
  764. SetErrPackage("Reset::Reset", m_csDevNo, eErr, MEC_DEVAPI_RF_Reset);
  765. AlarmDEC();
  766. return 1;
  767. }
  768. }
  769. int CContactlessCardFSM::InternalAcceptCard()
  770. {
  771. LOG_FUNCTION();
  772. int acceptTries = 0, err = 0;
  773. m_bWaitingAccept = true;
  774. DWORD dwBeginTime = GetTickCount();
  775. do {
  776. if (m_bExit) {
  777. m_bCancelAccept = true;
  778. break;
  779. }
  780. if (m_bCancelAccept) {
  781. err = 3;
  782. goto Err;
  783. }
  784. if (m_bWaitAccepteMore) {
  785. acceptTries = 0;
  786. m_bWaitAccepteMore = false;
  787. dwBeginTime = GetTickCount();
  788. }
  789. if (GetDevStatus(false)) {
  790. if (devStatus.eMediaPos == CI_MEDIA_RF) {
  791. LogEvent(Severity_Middle, LOG_EVT_CONTACTLESS_CARD_OP, "Contactless card op.");
  792. acceptTries = 0;
  793. goto Err;
  794. } else {
  795. acceptTries++;
  796. Sleep(ACCEPT_TRY_INTERVAL);
  797. }
  798. } else {
  799. err = 1;
  800. goto Err;
  801. }
  802. } while (GetTickCount() - dwBeginTime <= 55 * 1000);
  803. err = 2;
  804. Err:
  805. m_bExit = false;
  806. m_bWaitingAccept = false;
  807. if (m_bCancelAccept && err != 1)
  808. {
  809. if (GetDevStatus())
  810. {
  811. if (devStatus.eMediaPos == CI_MEDIA_PRESENT)
  812. {
  813. err = 4;
  814. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("cancel eject......");
  815. }
  816. }
  817. else
  818. err = 2;
  819. }
  820. return err;
  821. }
  822. int FindHexCharPosition(LPBYTE data, BYTE hexChar, int len)
  823. {
  824. int notExist = -1,ret = 1,pos = 0;
  825. for (; pos < len; ++pos)
  826. {
  827. BYTE high = (*(data+pos))&0xf0;
  828. BYTE low = (*(data+pos))&0x0f;
  829. if ((high>>4) != hexChar)
  830. ret++;
  831. else
  832. return ret;
  833. if (low != hexChar)
  834. ret++;
  835. else
  836. return ret;
  837. }
  838. ret = notExist;
  839. return ret;
  840. }
  841. int CContactlessCardFSM::AcceptCard(SpReqAnsContext<ContactlessCardService_Insert_Req, ContactlessCardService_Insert_Ans>::Pointer ctx)
  842. {
  843. LOG_FUNCTION();
  844. ctx->Ans.ICType = 0;
  845. m_pCardProcess->DataInit();
  846. LogEvent(Severity_Middle,LOG_EVT_CONTACTLESS_CARD_GREEN_ON,"ContactCard green on");
  847. m_bWaitAccepteMore = false;
  848. int rc = InternalAcceptCard();
  849. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("InternalAcceptCard ret:%d", rc);
  850. LogEvent(Severity_Middle,LOG_EVT_CONTACTLESS_CARD_GREEN_OFF,"ContactCard green off");
  851. if (rc == 0) {
  852. //FSMSetIssueFlag(false);
  853. if (ctx != NULL)
  854. {
  855. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("insert error_succeed");
  856. //FetchCard evt;
  857. //evt.status = 3;//oilyang@20181210 用于通知CardIssuer取消插卡
  858. //SpSendBroadcast(m_pEntity->GetFunction(), SP_MSG_OF(FetchCard), SP_MSG_SIG_OF(FetchCard), evt);
  859. ctx->Ans.ICData = "";
  860. int activeCardType;
  861. //int retICData = m_pCardProcess->DetectAndReadICData(CARD_MACHINE_RFIC, m_hDevHelper, "A000000333", activeCardType);
  862. //oilyang@20201014 add emv card support
  863. int retDetectAndRead = -1;
  864. if (!ctx->Req.aid.IsNullOrEmpty())
  865. {
  866. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("front business provide aid:[%s]",(const char*)ctx->Req.aid);
  867. CAutoArray<CSimpleStringA> aidReq;
  868. aidReq.Init(1);
  869. aidReq[0] = ctx->Req.aid;
  870. retDetectAndRead = m_pCardProcess->DetectAndReadICData(CARD_MACHINE_RFIC, m_hDevHelper, aidReq, activeCardType);
  871. }
  872. else {
  873. retDetectAndRead = m_pCardProcess->DetectAndReadICData(CARD_MACHINE_RFIC, m_hDevHelper, m_aidList, activeCardType);
  874. }
  875. if (retDetectAndRead < 0)
  876. {
  877. // -1和-2是上电或APDU交互失败,功能集循环调用
  878. if (retDetectAndRead == -1){
  879. SetErrPackage("AcceptCard::DetectAndReadICData(-1)", m_csDevNo, Error_Unexpect, MEC_DEVAPI_CARDSWIPER_ActiveICCard);
  880. ctx->Answer(Error_Interact, AlarmDEC());
  881. }
  882. else if (retDetectAndRead == -2){
  883. SetErrPackage("AcceptCard::DetectAndReadICData(-2)", m_csDevNo, Error_Unexpect, MEC_DEVAPI_CARDSWIPER_ICCommand);
  884. ctx->Answer(Error_Interact, AlarmDEC());
  885. }else if (retDetectAndRead == -3){
  886. SetErrPackage("AcceptCard::DetectAndReadICData(-3)", m_csDevNo, Error_Unexpect, MEC_DEVAPI_CARDSWIPER_ICCommand);
  887. ctx->Answer(Error_Interact, AlarmDEC());
  888. }
  889. return 2;
  890. }
  891. ctx->Ans.t2Account = ctx->Ans.ICData = "";
  892. ICData track2(false,0x57,0x00);
  893. ErrorCodeEnum eErr = Error_Unexpect;
  894. string t2ICAccount(""),t2ICCardSerial(""),t2ICCVC(""),t2ICTrack2(""),cardType;
  895. if (m_pCardProcess->FindTagValue(TAG_VECTOR_IC,track2,false,0) == -1)
  896. {
  897. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("no track2 data in ic");
  898. eErr = m_hDevHelper->HaltCard();
  899. if(Error_Succeed != eErr){
  900. SetErrPackage("AcceptCard::HaltCard", m_csDevNo, eErr, MEC_DEVAPI_RF_HaltCard);
  901. AlarmDEC();
  902. }
  903. ctx->Answer(Error_Interact);//can't find track2,retry 20150128
  904. }
  905. else
  906. {
  907. int pos = FindHexCharPosition(track2.value, 0x0d, track2.lenth);
  908. char *pICTrack2 = new char[128];
  909. ZeroMemory(pICTrack2, 128);
  910. HexBuf2StrBuf(track2.value, &pICTrack2, track2.lenth);
  911. pICTrack2[37] = '\0';
  912. char *ddd = new char[128];
  913. memset(ddd, 0, 128);
  914. memcpy(ddd, pICTrack2, pos - 1);
  915. t2ICTrack2 = pICTrack2;
  916. t2ICAccount = (char*)ddd;//oiltest
  917. LogWarn(Severity_Low, Error_Succeed, ContactlessCard_UserErrorCode_ReadAccount, CSimpleStringA::Format("split pos:%d, card acount:%s,%s"
  918. , pos, t2ICAccount.substr(0, 6).c_str(), t2ICAccount.substr(t2ICAccount.length() - 4, 4).c_str()));
  919. ctx->Ans.ICData = ctx->Ans.t2Account = t2ICAccount.c_str();
  920. ctx->Ans.ICType = 4;
  921. ctx->Ans.status = 0;
  922. delete[]ddd;
  923. delete[]pICTrack2;
  924. //m_hDevHelper->DeactContactlessICCard();
  925. }
  926. ctx->Answer(Error_Succeed);
  927. }
  928. }
  929. else if(rc == 2)
  930. {
  931. if (ctx != NULL)
  932. ctx->Answer(Error_TimeOut);
  933. }
  934. else if(rc == 3 || rc == 4)
  935. {
  936. if (ctx != NULL)
  937. {
  938. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("insert cancel (%d)",rc);
  939. ctx->Answer(Error_Cancel);
  940. }
  941. }else
  942. {
  943. //oilyang@20221212
  944. //actully,we reach here only when calling GetDevStatus failed
  945. //we have ContactlessCard AND CardIssuer,no need to throw Error_Unexpect here
  946. if (ctx != NULL)
  947. ctx->Answer(Error_DevNotAvailable);
  948. }
  949. return rc;
  950. }
  951. static CSimpleStringA GetStrData(TrackInfo trackInfo)
  952. {
  953. //LOG_FUNCTION();
  954. CSimpleStringA strRet;
  955. switch (trackInfo.eStatus) {
  956. case CI_DATA_OK:
  957. strRet = (char*)trackInfo.data;
  958. break;
  959. case CI_DATA_INVALID:
  960. strRet = "无效数据";
  961. break;
  962. //case CI_DATA_MISSING:
  963. default:
  964. strRet = "数据丢失";
  965. }
  966. return strRet;
  967. }
  968. int CContactlessCardFSM::SplitTrack2(CSimpleStringA pTrack2,Track2Data &decodeData)
  969. {
  970. if (pTrack2.GetLength() == 0)
  971. return -1;
  972. int dataLen = strlen(pTrack2);
  973. switch(dataLen)
  974. {
  975. case 28:
  976. decodeData.t2Region = CSimpleString(pTrack2,4);
  977. decodeData.t2Account = pTrack2.SubString(4,8);
  978. decodeData.t2CardSerial = pTrack2.SubString(14,8);//oilyang for 8 onecard
  979. decodeData.t2CVC = pTrack2.SubString(22,6);
  980. decodeData.t2ExpireDate = "";
  981. break;
  982. case 31:
  983. decodeData.t2Account = CSimpleString(pTrack2,16);
  984. decodeData.t2CardSerial = pTrack2.SubString(16,1);
  985. decodeData.t2CVC = pTrack2.SubString(17,6);
  986. decodeData.t2Region = pTrack2.SubString(23,4);
  987. decodeData.t2ExpireDate = pTrack2.SubString(27,4);
  988. break;
  989. case 25://AE Card
  990. decodeData.t2Account = CSimpleString(pTrack2, 15);
  991. decodeData.t2CardSerial = pTrack2.SubString(15, 1);
  992. decodeData.t2CVC = pTrack2.SubString(16, 5);
  993. decodeData.t2ExpireDate = pTrack2.SubString(21, 4);
  994. decodeData.t2Region = "";
  995. break;
  996. case 38:
  997. break;
  998. default:
  999. return -1;
  1000. }
  1001. decodeData.status = 0;
  1002. return 0;
  1003. }
  1004. int CContactlessCardFSM::PreOnline(SpReqAnsContext<ContactlessCardService_PreOnline_Req,ContactlessCardService_PreOnline_Ans>::Pointer ctx)
  1005. {
  1006. LOG_FUNCTION();
  1007. m_pCardProcess->DataInit();
  1008. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("<PreOnline>, bus data[%s]", ctx->Req.businessData.GetData());
  1009. m_pCardProcess->SplitBusinessData(ctx->Req.businessData,ctx->Req.businessData.GetLength());
  1010. m_pCardProcess->SplitBusinessData("DF690101",strlen("DF690101"));
  1011. int activeCardType;
  1012. //oilyang@20201014 add emv card support
  1013. int retDetectAndRead = -1;
  1014. ICData aidFromBus(false, 0x4f, 0x00);
  1015. if (m_pCardProcess->FindTagValue(TAG_VECTOR_BUS, aidFromBus, false, 0) == -1)
  1016. {
  1017. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("the front BusinessData han't provide aid data.");
  1018. retDetectAndRead = m_pCardProcess->DetectAndReadICData(CARD_MACHINE_RFIC, m_hDevHelper, m_aidList, activeCardType);
  1019. }
  1020. else {
  1021. char* pAIDTmp = new char[64];
  1022. memset(pAIDTmp, 0, 64);
  1023. HexBuf2StrBuf(aidFromBus.value, &pAIDTmp, aidFromBus.lenth);
  1024. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("<PreOnline>, the aid is[%s],len:%d .", pAIDTmp, strlen(pAIDTmp));
  1025. CAutoArray<CSimpleString> preAIDs;
  1026. preAIDs.Init(1);
  1027. preAIDs[0] = (CSimpleStringA)pAIDTmp;
  1028. retDetectAndRead = m_pCardProcess->DetectAndReadICData(CARD_MACHINE_RFIC, m_hDevHelper, preAIDs, activeCardType);
  1029. if (pAIDTmp != NULL)
  1030. delete[]pAIDTmp;
  1031. }
  1032. if (retDetectAndRead < 0)
  1033. {
  1034. // -1和-2是上电或APDU交互失败,功能集循环调用
  1035. if (retDetectAndRead == -1){
  1036. SetErrPackage("PreOnline::DetectAndReadICData(-1)", m_csDevNo, Error_Unexpect, MEC_DEVAPI_CARDSWIPER_ActiveICCard);
  1037. ctx->Answer(Error_Interact, AlarmDEC());
  1038. }
  1039. else if (retDetectAndRead == -2){
  1040. SetErrPackage("PreOnline::DetectAndReadICData(-2)", m_csDevNo, Error_Unexpect, MEC_DEVAPI_CARDSWIPER_ICCommand);
  1041. ctx->Answer(Error_Interact, AlarmDEC());
  1042. }else if (retDetectAndRead == -3){
  1043. SetErrPackage("PreOnline::DetectAndReadICData(-3)", m_csDevNo, Error_Unexpect, MEC_DEVAPI_CARDSWIPER_ICCommand);
  1044. ctx->Answer(Error_Interact, AlarmDEC());
  1045. }
  1046. return 0;
  1047. }
  1048. //if (m_cardType == CI_CARDTYPE_IC)
  1049. //{
  1050. // ProcessRestrict();
  1051. // CardholderVerify();
  1052. m_pCardProcess->TermRiskManage();
  1053. CSimpleStringA taaResult;
  1054. BYTE bt9f27 = 0;
  1055. int retTAA = m_pCardProcess->TermActionAnalyze(CARD_MACHINE_RFIC,m_hDevHelper,taaResult,true,m_bCDA,bt9f27);
  1056. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("TermActionAnalyze %d",retTAA);
  1057. switch(retTAA)
  1058. {//to be added oiltest 20140929
  1059. case -1: //some data may be wrong
  1060. break;
  1061. case 1: //terminal trans
  1062. break;
  1063. case 2: //to do trans end "TransEnd"
  1064. break;
  1065. default:
  1066. break;
  1067. }
  1068. ctx->Ans.result = taaResult;
  1069. // Dbg("[%d,%d,%d,%d]",m_TVR[0],m_TVR[1],m_TVR[2],m_TVR[3]);
  1070. //}
  1071. if (ctx->Ans.result.GetLength() == 0)
  1072. {
  1073. ctx->Answer(Error_Succeed);
  1074. return 0;
  1075. }
  1076. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("<PreOnline>, term action analyze result[%s]",(const char*)ctx->Ans.result);
  1077. //char tmpResult[1024,]result[1024];
  1078. //ZeroMemory(tmpResult,sizeof(tmpResult));
  1079. //ZeroMemory(result,sizeof(result));
  1080. //memcpy(tmpResult,ctx->Ans.result,ctx->Ans.result.GetLength());
  1081. string tmpResult, actionType, result = "", baseICData = "";
  1082. tmpResult = ctx->Ans.result;
  1083. char *pSomeICData = new char[1024];
  1084. ZeroMemory(pSomeICData, 1024);
  1085. int lenRet = m_pCardProcess->ConstructARQCData(tmpResult.substr(6, 4).c_str(), m_pDataToARQC, pSomeICData);
  1086. baseICData = pSomeICData;
  1087. if (pSomeICData != NULL)
  1088. delete[]pSomeICData;
  1089. char arqcLen[8];
  1090. ZeroMemory(arqcLen,sizeof(arqcLen));
  1091. #ifdef RVC_OS_WIN
  1092. itoa(lenRet, arqcLen, 10);
  1093. #else
  1094. sprintf(arqcLen, "%d", lenRet);
  1095. #endif // RVC_OS_WIN
  1096. ICData appExpiryDate(false,0x5f,0x24);
  1097. if (m_pCardProcess->FindTagValue(TAG_VECTOR_IC,appExpiryDate,false,0) == -1)
  1098. {
  1099. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("can't find expire date");
  1100. return 0;
  1101. }
  1102. char *pExpireDate = new char[12];
  1103. ZeroMemory(pExpireDate,12);
  1104. HexBuf2StrBuf(appExpiryDate.value,&pExpireDate,appExpiryDate.lenth);
  1105. ICData track2(false,0x57,0x00),ICCardSerial(false,0x5f,0x34);
  1106. ErrorCodeEnum eErr = Error_Unexpect;
  1107. string t2ICAccount(""),t2ICCardSerial(""),t2ICCVC(""),t2ICTrack2(""),cardType("0");
  1108. char *pICCardSerial = new char[4];
  1109. ZeroMemory(pICCardSerial,4);
  1110. if (m_pCardProcess->FindTagValue(TAG_VECTOR_IC,ICCardSerial,false) == -1)
  1111. {
  1112. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("can't find card serial.");
  1113. }
  1114. else
  1115. {
  1116. HexBuf2StrBuf(ICCardSerial.value,&pICCardSerial,ICCardSerial.lenth);
  1117. }
  1118. if (m_pCardProcess->FindTagValue(TAG_VECTOR_IC,track2,false,0) == -1)
  1119. {
  1120. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("no track2 data in ic");
  1121. }
  1122. else
  1123. {
  1124. int pos = FindHexCharPosition(track2.value,0x0d,track2.lenth);
  1125. char *pICTrack2 = new char[128];
  1126. ZeroMemory(pICTrack2,128);
  1127. HexBuf2StrBuf(track2.value,&pICTrack2,track2.lenth);
  1128. pICTrack2[37] = '\0';
  1129. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("<PreOnline>, split pos:%d", pos);
  1130. char *ddd = new char[40];
  1131. ZeroMemory(ddd,40);
  1132. memcpy(ddd,pICTrack2,pos-1);
  1133. char icTrack2Data[128];
  1134. ZeroMemory(icTrack2Data,sizeof(icTrack2Data));
  1135. Track2Data track2Data;
  1136. track2Data.status = 0;
  1137. track2Data.t2Account = "";
  1138. cmdDecodeMag2(pICTrack2,icTrack2Data);
  1139. if (SplitTrack2(icTrack2Data,track2Data) == 0)
  1140. {
  1141. t2ICAccount = track2Data.t2Account;
  1142. //t2ICCardSerial = track2Data.t2CardSerial;
  1143. t2ICCVC = track2Data.t2CVC;
  1144. t2ICTrack2 = pICTrack2;
  1145. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("done(ic).");
  1146. }
  1147. //}
  1148. if (strnicmp(track2Data.t2Account,ddd,strlen(ddd)))
  1149. {
  1150. t2ICCVC = "";
  1151. t2ICTrack2 = pICTrack2;
  1152. t2ICAccount = (char*)ddd;
  1153. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("contactless card countcount:%s,%s", t2ICAccount.substr(0, 6).c_str(), t2ICAccount.substr(t2ICAccount.length() - 4, 4).c_str());
  1154. }
  1155. t2ICCardSerial = pICCardSerial;
  1156. delete []ddd;
  1157. delete []pICTrack2;
  1158. }
  1159. //80 1e 80 0008 328ab54bfc986b85 07010103a0b000010a010000000000754048769000
  1160. if (m_pCardProcess->GetP1() == 0x1)
  1161. actionType = "ARQC";
  1162. else
  1163. actionType = "";
  1164. //【55域】
  1165. // 基本域:
  1166. // 9F26 8b 应用密文AC
  1167. // 9F27 1b 密文信息数据
  1168. // 9F10 max.32b 发卡行应用数据IAD
  1169. // 9F37 4b 不可预知数
  1170. // 9F36 2b 应用交易计数器ATC
  1171. // 95 5b 终端验证结果TVR
  1172. // 9A 3cn 交易日期(6位有效数字,YYMMDD)
  1173. // 9C 1cn 交易类型(2位有效数字)
  1174. // 9F02 6cn 授权金额(12位有效数字)
  1175. // 5F2A 2cn 交易货币代码(3位有效数字)
  1176. // 82 2b 应用交互特征AIP
  1177. // 9F1A 2cn 终端国家代码(3位有效数字)
  1178. // 9F03 6cn 其他金额(12位有效数字)
  1179. // 9F33 3b 终端性能 "E0C900"
  1180. // 可选域:
  1181. //添加9F26,9F27,9F10,9F33的数据
  1182. char *pCID = new char[4];
  1183. ZeroMemory(pCID, 4);
  1184. HexBuf2StrBuf(&bt9f27, &pCID, 1);
  1185. char *pIssueBankLen = new char[4];
  1186. ZeroMemory(pIssueBankLen, 4);
  1187. int len9f10 = tmpResult.length() - 26 - 4;
  1188. int lenHigh, lenLow;
  1189. len9f10 = len9f10 / 2;
  1190. lenHigh = len9f10 / 16;
  1191. lenLow = len9f10 % 16;
  1192. BYTE bt9f10;
  1193. bt9f10 = (lenHigh << 4) + lenLow;
  1194. HexBuf2StrBuf(&bt9f10, &pIssueBankLen, 1);
  1195. baseICData += "9F2608" + tmpResult.substr(10, 16) + "9F2701" + pCID + "9F10" + pIssueBankLen + tmpResult.substr(26, tmpResult.length() - 26 - 4) + "9F3303" + "E0C900";
  1196. result = "ACTION," + actionType + "|" + "ATCCODE," + tmpResult.substr(6, 4) + "|" + "ARQCCODE," + tmpResult.substr(10, 16) + "|"
  1197. + "MAC," + tmpResult.substr(26, tmpResult.length() - 26 - 4) + "|" + "ARQCSIZE," + string(arqcLen) + "|"
  1198. + "ARQCDATA," + m_pDataToARQC + "|EXPIREDATE," + pExpireDate + "|T2ACCOUNT," + t2ICAccount + "|T2CARDSERIAL," + t2ICCardSerial
  1199. + "|T2CVC," + t2ICCVC + "|T2TRACK2," + t2ICTrack2 + "|CARDCAT," + cardType + "|ICTAGS," + baseICData;
  1200. ctx->Ans.result = result.c_str();
  1201. string txtresult = "";
  1202. txtresult = "ACTION," + actionType + "|" + "ATCCODE," + tmpResult.substr(6, 4) + "|" + "ARQCCODE," + tmpResult.substr(10, 16) + "|"
  1203. + "MAC," + tmpResult.substr(26, tmpResult.length() - 26 - 4) + "|" + "ARQCSIZE," + string(arqcLen) + "|"
  1204. + "ARQCDATA," + m_pDataToARQC + "|T2ACCOUNT(F6)," + t2ICAccount.substr(0, 6) + "|T2ACCOUNT(L4)," + t2ICAccount.substr(t2ICAccount.length() - 4, 4)
  1205. + "|T2CARDSERIAL(len)," + t2ICCardSerial + "|CARDCAT," + cardType;
  1206. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("data to host(less)[%s],baseICData length:%d", txtresult.c_str(), baseICData.length());
  1207. if (m_pDataToARQC != NULL)
  1208. {
  1209. delete []m_pDataToARQC;
  1210. m_pDataToARQC = NULL;
  1211. }
  1212. ctx->Answer(Error_Succeed);
  1213. return 0;
  1214. }
  1215. int CContactlessCardFSM::PostOnline(SpReqAnsContext<ContactlessCardService_PostOnline_Req,ContactlessCardService_PostOnline_Ans>::Pointer ctx)
  1216. {
  1217. LOG_FUNCTION();
  1218. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("post online data[%s]",(LPCTSTR)ctx->Req.data);
  1219. m_pCardProcess->SplitOnlineReplyData(ctx->Req.data,strlen(ctx->Req.data));
  1220. int issBnkAuth = m_pCardProcess->IssueBankAuth(CARD_MACHINE_RFIC,m_hDevHelper);
  1221. CSimpleStringA csTransEnd;
  1222. if (issBnkAuth == 0)
  1223. {
  1224. int transEnd = m_pCardProcess->TransEnd(CARD_MACHINE_RFIC,m_hDevHelper,m_bCDA);
  1225. if (transEnd == 0)
  1226. csTransEnd = "TRANSEND,0";
  1227. else if (transEnd == 1)
  1228. csTransEnd = "TRANSEND,1";
  1229. }
  1230. else
  1231. csTransEnd = "TRANSEND,1";
  1232. ctx->Ans.result = csTransEnd;
  1233. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("PostOnline, issBnkAuth:%d, csTransEnd:%s", issBnkAuth, csTransEnd.GetData());
  1234. ctx->Answer(Error_Succeed);
  1235. return 0;
  1236. }
  1237. int CContactlessCardFSM::EjectCard(SpReqAnsContext<ContactlessCardService_Eject_Req,ContactlessCardService_Eject_Ans>::Pointer ctx)
  1238. {
  1239. LOG_FUNCTION();
  1240. m_pCardProcess->DataInit();
  1241. int ret = 0;
  1242. DWORD dwStart = GetTickCount();
  1243. DWORD dwEnd = dwStart;
  1244. while(1)
  1245. {
  1246. if (m_bExit)
  1247. {
  1248. ret = 2;
  1249. break;
  1250. }
  1251. dwEnd = GetTickCount();
  1252. if ((dwEnd-dwStart) > 58*1000)
  1253. {
  1254. ret = 2;
  1255. break;
  1256. }
  1257. ErrorCodeEnum eErr = m_hDevHelper->GetDevStatus(devStatus);
  1258. if (eErr == Error_Succeed)
  1259. {
  1260. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("EjectCard, devStatus.eMedia %d",devStatus.eMediaPos);
  1261. if (devStatus.eMediaPos == CI_MEDIA_RF || devStatus.eMediaPos == CI_MEDIA_NOTPRESENT)
  1262. {
  1263. if (devStatus.eMediaPos == CI_MEDIA_NOTPRESENT)
  1264. ret = 0;
  1265. else if (devStatus.eMediaPos == CI_MEDIA_RF)
  1266. ret = 1;
  1267. break;
  1268. }
  1269. }
  1270. Sleep(100);
  1271. }
  1272. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("eject return.");
  1273. if (ctx != NULL)
  1274. ctx->Answer(Error_Succeed);
  1275. return ret;
  1276. }
  1277. int CContactlessCardFSM::WaitFetchingCard()
  1278. {
  1279. LOG_FUNCTION();
  1280. int waitTries = 0;
  1281. LogEvent(Severity_Middle,LOG_EVT_CONTACTLESS_CARD_GREEN_ON,"ContactCard(fetch) warning on");
  1282. do {
  1283. if (GetDevStatus(false)){
  1284. if (devStatus.eMediaPos == CI_MEDIA_RF){
  1285. Sleep(WAIT_INTERVAL);
  1286. waitTries++;
  1287. }
  1288. else if (devStatus.eMediaPos == CI_MEDIA_NOTPRESENT){
  1289. waitTries = 0;
  1290. LogEvent(Severity_Middle,LOG_EVT_CONTACTLESS_CARD_GREEN_OFF,"ContactCard(fetch) warning off");
  1291. return 0;
  1292. }
  1293. }else
  1294. {
  1295. LogEvent(Severity_Middle,LOG_EVT_CONTACTLESS_CARD_GREEN_OFF,"ContactCard(fetch) warning off");
  1296. return 1;
  1297. }
  1298. }while (waitTries < WAIT_TRY_NUM);
  1299. LogEvent(Severity_Middle,LOG_EVT_CONTACTLESS_CARD_GREEN_OFF,"ContactCard(fetch) warning off");
  1300. return 2;
  1301. }
  1302. int CContactlessCardFSM::QueryCardInfo(SpReqAnsContext<ContactlessCardService_QueryCardInfo_Req, ContactlessCardService_QueryCardInfo_Ans>::Pointer ctx)
  1303. {
  1304. RFICReaderStatus devStatus;
  1305. ErrorCodeEnum eErr = m_hDevHelper->GetDevStatus(devStatus);
  1306. if (eErr != Error_Succeed)
  1307. {
  1308. SetErrPackage("QueryCardInfo::GetDevStatus", m_csDevNo, eErr, MEC_DEVAPI_RF_GetDevStatus);
  1309. AlarmDEC();
  1310. ctx->Answer(TransECWithRepeat(Error_Unexpect));
  1311. return 1;
  1312. }
  1313. int ret = 0;
  1314. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("QueryCardInfo, eMedia pos:%d",devStatus.eMediaPos);
  1315. switch(devStatus.eMediaPos)
  1316. {
  1317. case CI_MEDIA_IC:
  1318. ret = 2;
  1319. break;
  1320. case CI_MEDIA_NOT_IC:
  1321. ret = 3;
  1322. break;
  1323. case CI_MEDIA_RF:
  1324. ret = 4;
  1325. break;
  1326. case CI_MEDIA_NOTPRESENT:
  1327. default:
  1328. ret = 0;
  1329. break;
  1330. }
  1331. ctx->Ans.position = ret;
  1332. ctx->Answer(Error_Succeed);
  1333. return ret;
  1334. }
  1335. void CContactlessCardFSM::ToLogWarnInfoAboutTermCustom()
  1336. {
  1337. LOG_FUNCTION();
  1338. ToLogWarnInfoAboutTerm();
  1339. CSmartPointer<IConfigInfo> spConfigRoot;
  1340. GetEntityBase()->GetFunction()->OpenConfig(Config_Root, spConfigRoot);
  1341. CSimpleStringA strVendor(true);
  1342. spConfigRoot->ReadConfigValue("Device.PinPad", "Vendor", strVendor);
  1343. //中世顺根据ContactlessCard的szType值判断机型信息
  1344. if (!m_csMachineType.Compare("RVC.Stand2S", true) && !strVendor.Compare("ZSS", true)) {
  1345. //先读取系统变量是否有该值?
  1346. CSimpleStringA deviceInfo(true);
  1347. GetEntityBase()->GetFunction()->GetSysVar("zssInfo", deviceInfo);
  1348. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("deviceInfo = %s", deviceInfo.GetData());
  1349. ///*TODO(80374374@4/3/2023): If it need execute every time */
  1350. if (!deviceInfo.Compare("ZSS", true)) {
  1351. //读取运行时信息,如果有值,不再写,如果没有值,读取告警的信息
  1352. //这中间会存在这里还在写,但其他模块已经要去读取该运行时的信息了,可能有先后顺序?
  1353. CSimpleStringA strWarnMsg(true);
  1354. CSimpleStringA szTypeInfo(true);
  1355. CSimpleStringA deviceType(true);
  1356. CSmartPointer<IConfigInfo> spConfigRun;
  1357. GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spConfigRun);
  1358. spConfigRun->ReadConfigValue("Run", "WarnMsg", strWarnMsg);
  1359. if (!strWarnMsg.IsNullOrEmpty()) {
  1360. Json::Value root;
  1361. Json::Reader reader;
  1362. if (reader.parse((const char*)strWarnMsg, root)) {
  1363. szTypeInfo = root.isMember("szType") ? CSimpleStringA(root["szType"].asCString()) : "";
  1364. if (!szTypeInfo.IsNullOrEmpty()) {
  1365. deviceType = szTypeInfo.Compare("IDC-CTR603-6001", true) == 0 ? "ZSS9100" : "Other";
  1366. GetEntityBase()->GetFunction()->SetSysVar("zssInfo", deviceType, true);
  1367. //加个告警?
  1368. LogWarn(Severity_Low, Error_Unexpect, ContactlessCard_UserErrorCode_ZssDeviceInfo, deviceType.GetData());
  1369. }
  1370. }
  1371. }
  1372. }
  1373. }
  1374. }