ContactlessFSM.cpp 40 KB

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