ContactlessFSM.cpp 64 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148
  1. #include "stdafx.h"
  2. #include "ContactlessFSM.h"
  3. #include "EventCode.h"
  4. #include "ContactlessCard_msg_g.h"
  5. #include "ContactlessCard_UserErrorCode.h"
  6. #include "CommDevEntityErrorCode.h"
  7. #include <map>
  8. #include "publicFunExport.h"
  9. #ifdef RVC_OS_WIN
  10. #else
  11. #include <dlfcn.h>
  12. #endif //RVC_OS_WIN
  13. const int GET_DEV_STATUS_COUNT = 1;
  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 = 1;
  22. class CContactlessCardEntity;
  23. void CContactlessCardFSM::s0_on_entry()
  24. {
  25. LOG_FUNCTION();
  26. m_currentFSMState = 0;
  27. SetDevState(DEVICE_STATUS_NOT_READY);
  28. FSMEvent *e = new FSMEvent(USER_EVT_INIT);
  29. PostEventFIFO(e);
  30. }
  31. void CContactlessCardFSM::s0_on_exit()
  32. {
  33. LOG_FUNCTION();
  34. }
  35. unsigned int CContactlessCardFSM::s0_on_event(FSMEvent* e)
  36. {
  37. LOG_FUNCTION();
  38. if (e->iEvt == USER_EVT_INIT) {
  39. InitTask* task = new InitTask(this);
  40. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  41. e->SetHandled();
  42. return 0;
  43. }else if (e->iEvt == USER_EVT_QUIT) {
  44. e->SetHandled();
  45. return 0;
  46. }
  47. return 0;
  48. }
  49. void CContactlessCardFSM::s1_on_entry()
  50. {
  51. LOG_FUNCTION();
  52. m_currentFSMState = 1;
  53. }
  54. void CContactlessCardFSM::s1_on_exit()
  55. {
  56. LOG_FUNCTION();
  57. }
  58. unsigned int CContactlessCardFSM::s1_on_event(FSMEvent* event)
  59. {
  60. LOG_FUNCTION();
  61. if (event->iEvt == USER_EVT_INITFINISHED) {
  62. event->SetHandled();
  63. int err = event->param1;
  64. if (err == 0) {
  65. return 0;
  66. } else {
  67. return 1;
  68. }
  69. }else if (event->iEvt == USER_EVT_QUIT) {
  70. event->SetHandled();
  71. return 0;
  72. }
  73. return 0;
  74. }
  75. //Idle
  76. void CContactlessCardFSM::s2_on_entry()
  77. {
  78. LOG_FUNCTION();
  79. m_currentFSMState = 2;
  80. SetDevState(DEVICE_STATUS_NORMAL);
  81. m_resetTimes = 0;
  82. m_testResult = Error_Succeed;
  83. }
  84. void CContactlessCardFSM::s2_on_exit()
  85. {
  86. LOG_FUNCTION();
  87. }
  88. unsigned int CContactlessCardFSM::s2_on_event(FSMEvent* pEvt)
  89. {
  90. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s2 evt(%d)",pEvt->iEvt);
  91. int ret = 0;
  92. switch(pEvt->iEvt)
  93. {
  94. case USER_EVT_JS_READ:
  95. {
  96. ReadJSEvent* rje = dynamic_cast<ReadJSEvent*>(pEvt);
  97. m_bCancelRead = false;
  98. m_bPageExit = false;
  99. ReadJSTask* task = new ReadJSTask(this);
  100. task->ctx = rje->ctx;
  101. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  102. pEvt->SetHandled();
  103. }
  104. break;
  105. case USER_EVT_JS_EJECT:
  106. {
  107. EjectJSEvent* eje = dynamic_cast<EjectJSEvent*>(pEvt);
  108. m_bPageExit = false;
  109. EjectJSTask* task = new EjectJSTask(this);
  110. task->ctx = eje->ctx;
  111. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  112. pEvt->SetHandled();
  113. }
  114. break;
  115. case USER_EVT_JS_POSTONLINE:
  116. {
  117. PostOnlineJSEvent* pje = dynamic_cast<PostOnlineJSEvent*>(pEvt);
  118. m_bCancelRead = false;
  119. m_bPageExit = false;
  120. PostOnlineJSTask* task = new PostOnlineJSTask(this);
  121. task->ctx = pje->ctx;
  122. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  123. pEvt->SetHandled();
  124. }
  125. break;
  126. case USER_EVT_JS_READ_CANCEL:
  127. {
  128. m_bCancelRead = true;
  129. pEvt->SetHandled();
  130. }
  131. break;
  132. case USER_EVT_ACCEPT:
  133. {
  134. CardAcceptEvent *cae = dynamic_cast<CardAcceptEvent*>(pEvt);
  135. m_bCancelAccept = false;
  136. AcceptTask* task = new AcceptTask(this);
  137. task->ctx = cae->ctx;
  138. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  139. pEvt->SetHandled();
  140. }
  141. break;
  142. case USER_EVT_QUERY_CARD_INFO:
  143. {
  144. pEvt->SetHandled();
  145. QueryCardInfoEvent *pQCIE = dynamic_cast<QueryCardInfoEvent*>(pEvt);
  146. QueryCardInfoTask* task = new QueryCardInfoTask(this);
  147. task->ctx = pQCIE->ctx;
  148. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  149. return 0;
  150. }
  151. case USER_EVT_EJECT:
  152. {
  153. CardEjectEvent *cee;
  154. if (pEvt->iEvt == USER_EVT_EJECT)
  155. cee = dynamic_cast<CardEjectEvent*>(pEvt);
  156. EjectTask *task= new EjectTask(this);
  157. if (pEvt->iEvt == USER_EVT_EJECT)
  158. task->ctx = cee->ctx;
  159. else
  160. task->ctx = NULL;
  161. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  162. pEvt->SetHandled();
  163. return 0;
  164. }
  165. case USER_EVT_EXIT:
  166. m_bExit = true;
  167. pEvt->SetHandled();
  168. break;
  169. case USER_EVT_QUIT:
  170. pEvt->SetHandled();
  171. break;
  172. default:
  173. break;
  174. }
  175. return ret;
  176. }
  177. //accepting
  178. void CContactlessCardFSM::s3_on_entry()
  179. {
  180. LOG_FUNCTION();
  181. m_currentFSMState = 3;
  182. }
  183. void CContactlessCardFSM::s3_on_exit()
  184. {
  185. LOG_FUNCTION();
  186. }
  187. unsigned int CContactlessCardFSM::s3_on_event(FSMEvent* pEvt)
  188. {
  189. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s3 evt (%d,%d)",pEvt->iEvt,pEvt->param1);
  190. int ret = 0;
  191. switch(pEvt->iEvt)
  192. {
  193. case USER_EVT_ACCEPTFINISHED:
  194. {
  195. pEvt->SetHandled();
  196. switch(pEvt->param1)
  197. {
  198. case 0:
  199. case 1:
  200. case 2:
  201. case 3:
  202. case 4:
  203. ret = pEvt->param1;
  204. break;
  205. default:
  206. ret = 1;
  207. break;
  208. }
  209. }
  210. break;
  211. case USER_EVT_ACCEPT_CANCEL:
  212. m_bCancelAccept = true;
  213. pEvt->SetHandled();
  214. ret = 3;
  215. break;
  216. case USER_EVT_QUERY_CARD_INFO:
  217. {
  218. pEvt->SetHandled();
  219. QueryCardInfoEvent *pQCIE = dynamic_cast<QueryCardInfoEvent*>(pEvt);
  220. QueryCardInfoTask* task = new QueryCardInfoTask(this);
  221. task->ctx = pQCIE->ctx;
  222. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  223. return 0;
  224. }
  225. case USER_EVT_EXIT:
  226. m_bExit = true;
  227. pEvt->SetHandled();
  228. break;
  229. case USER_EVT_QUIT:
  230. pEvt->SetHandled();
  231. break;
  232. default:
  233. break;
  234. }
  235. return ret;
  236. }
  237. //Hold
  238. void CContactlessCardFSM::s4_on_entry()
  239. {
  240. LOG_FUNCTION();
  241. m_currentFSMState = 4;
  242. }
  243. void CContactlessCardFSM::s4_on_exit()
  244. {
  245. LOG_FUNCTION();
  246. }
  247. unsigned int CContactlessCardFSM::s4_on_event(FSMEvent* pEvt)
  248. {
  249. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s4 evt(%d,%d)",pEvt->iEvt,pEvt->param1);
  250. switch(pEvt->iEvt){
  251. case USER_EVT_ACCEPT:
  252. {
  253. CardAcceptEvent *cae = dynamic_cast<CardAcceptEvent*>(pEvt);
  254. m_bCancelAccept = false;
  255. AcceptTask* task = new AcceptTask(this);
  256. task->ctx = cae->ctx;
  257. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  258. pEvt->SetHandled();
  259. }
  260. break;
  261. case USER_EVT_PREONLINE:
  262. {
  263. PreOnlineEvent* poe = dynamic_cast<PreOnlineEvent*>(pEvt);
  264. PreOnlineTask* task = new PreOnlineTask(this);
  265. task->ctx = poe->ctx;
  266. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  267. pEvt->SetHandled();
  268. return 0;
  269. }
  270. case USER_EVT_POSTONLINE:
  271. {
  272. PostOnlineEvent* poe = dynamic_cast<PostOnlineEvent*>(pEvt);
  273. PostOnlineTask* task = new PostOnlineTask(this);
  274. task->ctx = poe->ctx;
  275. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  276. pEvt->SetHandled();
  277. return 0;
  278. }
  279. case USER_EVT_EXIT:
  280. case USER_EVT_EJECT:
  281. {
  282. pEvt->SetHandled();
  283. CardEjectEvent *cee;
  284. if (pEvt->iEvt == USER_EVT_EJECT)
  285. cee = dynamic_cast<CardEjectEvent*>(pEvt);
  286. EjectTask *task= new EjectTask(this);
  287. if (pEvt->iEvt == USER_EVT_EJECT)
  288. task->ctx = cee->ctx;
  289. else
  290. task->ctx = NULL;
  291. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  292. return 0;
  293. }
  294. case USER_EVT_QUERY_CARD_INFO:
  295. {
  296. pEvt->SetHandled();
  297. QueryCardInfoEvent *pQCIE = dynamic_cast<QueryCardInfoEvent*>(pEvt);
  298. QueryCardInfoTask* task = new QueryCardInfoTask(this);
  299. task->ctx = pQCIE->ctx;
  300. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  301. return 0;
  302. }
  303. case USER_EVT_QUERY_CARD_INFO_FINISHED:
  304. {
  305. pEvt->SetHandled();
  306. if (pEvt->param1 == 0)
  307. return 0;
  308. else
  309. return 1;
  310. }
  311. case USER_EVT_QUIT:
  312. {
  313. pEvt->SetHandled();
  314. return 0;
  315. }
  316. case USER_EVT_ACCEPT_CANCEL:
  317. m_bCancelAccept = true;
  318. pEvt->SetHandled();
  319. default:
  320. break;
  321. }
  322. return 0;
  323. }
  324. //Reading
  325. void CContactlessCardFSM::s5_on_entry()
  326. {
  327. LOG_FUNCTION();
  328. m_currentFSMState = 5;
  329. }
  330. void CContactlessCardFSM::s5_on_exit()
  331. {
  332. LOG_FUNCTION();
  333. }
  334. unsigned int CContactlessCardFSM::s5_on_event(FSMEvent* pEvt)
  335. {
  336. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s5 event(%d)",pEvt->iEvt);
  337. switch(pEvt->iEvt)
  338. {
  339. case USER_EVT_EXIT:
  340. {
  341. EjectTask *task= new EjectTask(this);
  342. task->ctx = NULL;
  343. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  344. pEvt->SetHandled();
  345. return 0;
  346. }
  347. break;
  348. case USER_EVT_QUIT:
  349. {
  350. pEvt->SetHandled();
  351. return 0;
  352. }
  353. default:
  354. break;
  355. }
  356. return 0;
  357. }
  358. //Ejecting
  359. void CContactlessCardFSM::s6_on_entry()
  360. {
  361. LOG_FUNCTION();
  362. m_currentFSMState = 6;
  363. }
  364. void CContactlessCardFSM::s6_on_exit()
  365. {
  366. LOG_FUNCTION();
  367. }
  368. unsigned int CContactlessCardFSM::s6_on_event(FSMEvent* pEvt)
  369. {
  370. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s6 evt(%d,%d)",pEvt->iEvt,pEvt->param1);
  371. int ret = 0;
  372. switch(pEvt->iEvt)
  373. {
  374. case USER_EVT_EJECTFINISHED:
  375. pEvt->SetHandled();
  376. ret = pEvt->param1;
  377. break;
  378. case USER_EVT_QUIT:
  379. case USER_EVT_EXIT:
  380. pEvt->SetHandled();
  381. break;
  382. default:
  383. break;
  384. }
  385. return ret;
  386. }
  387. void CContactlessCardFSM::s7_on_entry()
  388. {
  389. LOG_FUNCTION();
  390. m_currentFSMState = 7;
  391. WaitFetchingTask* task = new WaitFetchingTask(this);
  392. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  393. }
  394. void CContactlessCardFSM::s7_on_exit()
  395. {
  396. LOG_FUNCTION();
  397. }
  398. unsigned int CContactlessCardFSM::s7_on_event(FSMEvent* pEvt)
  399. {
  400. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s7 evt(%d)",pEvt->iEvt);
  401. switch(pEvt->iEvt)
  402. {
  403. case USER_EVT_WAITFINISHED:
  404. {
  405. pEvt->SetHandled();
  406. if (pEvt->param1 == 0) {
  407. FetchCard evt;
  408. evt.status = 0;
  409. SpSendBroadcast(m_pEntity->GetFunction(),SP_MSG_OF(FetchCard),SP_MSG_SIG_OF(FetchCard),evt);
  410. LogEvent(Severity_Middle,LOG_EVT_CONTACTLESS_CARD_OP,"ContactlessCard op.");
  411. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("客户取走卡片msg发送");
  412. return 0;
  413. } else if (pEvt->param1 == 1) {
  414. //FetchCard evt;
  415. //evt.status = 1;
  416. //SpSendBroadcast(m_pEntity->GetFunction(),SP_MSG_OF(FetchCard),SP_MSG_SIG_OF(FetchCard),evt);
  417. //Dbg("取卡时设备故障");
  418. //return 1;
  419. } else {
  420. FetchCard evt;
  421. evt.status = 2;
  422. SpSendBroadcast(m_pEntity->GetFunction(),SP_MSG_OF(FetchCard),SP_MSG_SIG_OF(FetchCard),evt);
  423. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("客户未取卡超时msg发送");
  424. LogWarn(Severity_Middle, Error_NotInit, ContactlessCard_UserErrorCode_FORGET_FETCH, "Customer forget fetch card.");
  425. return 2;
  426. }
  427. }
  428. case USER_EVT_QUERY_CARD_INFO:
  429. {
  430. pEvt->SetHandled();
  431. QueryCardInfoEvent *pQCIE = dynamic_cast<QueryCardInfoEvent*>(pEvt);
  432. QueryCardInfoTask* task = new QueryCardInfoTask(this);
  433. task->ctx = pQCIE->ctx;
  434. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  435. return 0;
  436. }
  437. case USER_EVT_QUIT:
  438. {
  439. pEvt->SetHandled();
  440. return 0;
  441. }
  442. default:
  443. break;
  444. }
  445. return 0;
  446. }
  447. //capture
  448. void CContactlessCardFSM::s8_on_entry()
  449. {
  450. LOG_FUNCTION();
  451. m_currentFSMState = 8;
  452. }
  453. void CContactlessCardFSM::s8_on_exit()
  454. {
  455. LOG_FUNCTION();
  456. }
  457. unsigned int CContactlessCardFSM::s8_on_event(FSMEvent* pEvt)
  458. {
  459. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s8 evt(%d)",pEvt->iEvt);
  460. if (pEvt->iEvt == USER_EVT_CAPTUREFINISHED){
  461. pEvt->SetHandled();
  462. int err = pEvt->param1;
  463. if (err == 0)
  464. return 0;
  465. else
  466. return 1;
  467. }else if (pEvt->iEvt == USER_EVT_QUIT) {
  468. pEvt->SetHandled();
  469. return 0;
  470. }
  471. return 0;
  472. }
  473. void CContactlessCardFSM::s9_on_entry()
  474. {
  475. LOG_FUNCTION();
  476. m_currentFSMState = 9;
  477. SetDevState(DEVICE_STATUS_FAULT);
  478. if (m_bNeedReset) {
  479. FSMEvent* e = new FSMEvent(USER_EVT_RESET);
  480. PostEventFIFO(e);
  481. }
  482. else {
  483. m_testResult = Error_InvalidState;
  484. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("device is fault, wait for restart entity");
  485. }
  486. }
  487. void CContactlessCardFSM::s9_on_exit()
  488. {
  489. LOG_FUNCTION();
  490. }
  491. unsigned int CContactlessCardFSM::s9_on_event(FSMEvent* pEvt)
  492. {
  493. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s9 evt(%d)(%d)",pEvt->iEvt, pEvt->param1);
  494. switch(pEvt->iEvt)
  495. {
  496. case USER_EVT_RESET:
  497. {
  498. pEvt->SetHandled();
  499. m_resetTimes++;
  500. if (m_resetTimes > MAX_RESET_TIMES_PERIOD)
  501. {
  502. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("restart tried %d times,give up",m_resetTimes);
  503. m_testResult = Error_InvalidState;
  504. LogWarn(Severity_Middle,Error_Unexpect, ContactlessCard_UserErrorCode_Reset_Failed,"reset failed more times");
  505. return 0;
  506. }
  507. ResetDeviceEvent* rde = dynamic_cast<ResetDeviceEvent*>(pEvt);
  508. ResetTask* task = new ResetTask(this);
  509. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  510. return 0;
  511. }
  512. break;
  513. case USER_EVT_RESETFINISHED:
  514. {
  515. ResetFinishedEvent *rfe = dynamic_cast<ResetFinishedEvent*>(pEvt);
  516. return rfe->param1;
  517. }
  518. case USER_EVT_QUERY_CARD_INFO:
  519. {
  520. pEvt->SetHandled();
  521. QueryCardInfoEvent *pQCIE = dynamic_cast<QueryCardInfoEvent*>(pEvt);
  522. QueryCardInfoTask* task = new QueryCardInfoTask(this);
  523. task->ctx = pQCIE->ctx;
  524. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  525. return 0;
  526. }
  527. case USER_EVT_QUIT:
  528. pEvt->SetHandled();
  529. return 0;
  530. case USER_EVT_ACCEPT_CANCEL:
  531. m_bCancelAccept = true;
  532. pEvt->SetHandled();
  533. break;
  534. default:
  535. break;
  536. }
  537. return 0;
  538. }
  539. void CContactlessCardFSM::s10_on_entry()
  540. {
  541. LOG_FUNCTION();
  542. m_currentFSMState = 10;
  543. }
  544. void CContactlessCardFSM::s10_on_exit()
  545. {
  546. LOG_FUNCTION();
  547. }
  548. unsigned int CContactlessCardFSM::s10_on_event(FSMEvent* pEvt)
  549. {
  550. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s10 event(%d)", pEvt->iEvt);
  551. int ret = 0;
  552. switch (pEvt->iEvt)
  553. {
  554. case USER_EVT_JS_READ_FINISHED:
  555. {
  556. pEvt->SetHandled();
  557. ret = 0;
  558. }
  559. break;
  560. case USER_EVT_JS_POSTONLINEFINISHED:
  561. {
  562. pEvt->SetHandled();
  563. ret = 0;
  564. }
  565. break;
  566. case USER_EVT_JS_READ_CANCEL:
  567. {
  568. m_bCancelRead = true;
  569. pEvt->SetHandled();
  570. ret = 0;
  571. }
  572. break;
  573. case EVT_MAINPAGE_DISPLAY:
  574. {
  575. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("S10 receive exit to main page");
  576. m_bPageExit = true;
  577. pEvt->SetHandled();
  578. ret = 0;
  579. }
  580. break;
  581. default:
  582. break;
  583. }
  584. return ret;
  585. }
  586. void CContactlessCardFSM::s11_on_entry()
  587. {
  588. LOG_FUNCTION();
  589. m_currentFSMState = 11;
  590. }
  591. void CContactlessCardFSM::s11_on_exit()
  592. {
  593. LOG_FUNCTION();
  594. }
  595. unsigned int CContactlessCardFSM::s11_on_event(FSMEvent* pEvt)
  596. {
  597. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s11 event(%d)", pEvt->iEvt);
  598. int ret = 0;
  599. switch (pEvt->iEvt)
  600. {
  601. case USER_EVT_JS_EJECTFINISHED:
  602. {
  603. pEvt->SetHandled();
  604. ret = pEvt->param1;
  605. }
  606. break;
  607. case EVT_MAINPAGE_DISPLAY:
  608. {
  609. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("S11 receive exit to main page");
  610. m_bPageExit = true;
  611. pEvt->SetHandled();
  612. ret = 0;
  613. }
  614. break;
  615. default:
  616. break;
  617. }
  618. return ret;
  619. }
  620. ErrorCodeEnum CContactlessCardFSM::OnInit()
  621. {
  622. LOG_FUNCTION();
  623. AddStateHooker(this);
  624. auto pEntity = GET_DEV_ENTITY_BASE_POINTER();
  625. pEntity->InitializeVendorLogSwitch();
  626. FulfillAdapterInfoFrom(pEntity->vendorLibInfo);
  627. m_pCardProcess = new CCardProcess();
  628. if (m_pCardProcess == NULL)//almost no use...
  629. {
  630. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2J19")("create card process failed.");
  631. return Error_Resource;
  632. }
  633. CSystemStaticInfo sysInfo;
  634. m_csMachineType = "";
  635. GetEntityBase()->GetFunction()->GetSystemStaticInfo(sysInfo);
  636. m_csMachineType = sysInfo.strMachineType;
  637. m_bOpening = true;
  638. ErrorCodeEnum errCode = Load();
  639. if (errCode != Error_Succeed)
  640. {
  641. //DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Load failed(%d).",errCode);
  642. SetDevInitFlag(false);//打开失败
  643. }
  644. devStatus.eMediaPos = CI_MEDIA_NOTPRESENT;
  645. m_bOpening = false;
  646. return Error_Succeed;
  647. }
  648. ErrorCodeEnum CContactlessCardFSM::OnExit()
  649. {
  650. LOG_FUNCTION();
  651. ErrorCodeEnum eExit;
  652. long l_beginTime, l_endTime;
  653. if (m_hDevHelper != nullptr)
  654. {
  655. l_beginTime = SP::Module::Comm::RVCGetTickCount();
  656. eExit = m_hDevHelper->GetDevStatus(devStatus);
  657. l_endTime = SP::Module::Comm::RVCGetTickCount();
  658. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("OnExit::GetDevStatus eMedia:%d, eErr:%d", devStatus.eMediaPos, eExit);
  659. if (eExit == Error_Succeed)
  660. {
  661. if (devStatus.eMediaPos == CI_MEDIA_PRESENT){
  662. }
  663. }
  664. l_beginTime = SP::Module::Comm::RVCGetTickCount();
  665. eExit = m_hDevHelper->DevClose();
  666. l_endTime = SP::Module::Comm::RVCGetTickCount();
  667. if (eExit == Error_Succeed) {
  668. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::DevClose").setCostTime(l_endTime - l_beginTime)("读卡器关闭成功");
  669. }
  670. else{
  671. SetErrorAndLog(eExit, MEC_DEVAPI_RF_DevClose, "DevAdapter::DevClose", __FUNCTION__, false, l_endTime - l_beginTime, "", "读卡器关闭失败");
  672. }
  673. }
  674. FSMImpl<CContactlessCardFSM>::OnExit();
  675. return Error_Succeed;
  676. }
  677. ErrorCodeEnum CContactlessCardFSM::Load()
  678. {
  679. LOG_FUNCTION();
  680. ErrorCodeEnum hr;
  681. long l_beginTime, l_endTime;
  682. int initTries = 0;
  683. ErrorCodeEnum eErrDev = Error_Unexpect;
  684. CSimpleString errMsg(true);
  685. CSmartPointer<IEntityFunction> spEntityFunction = GetEntityBase()->GetFunction();
  686. CSmartPointer<IConfigInfo> spConfig;
  687. CSimpleStringA csBinPath,csBackslash("\\");
  688. ErrorCodeEnum eErrPath = GetEntityBase()->GetFunction()->GetPath("Bin", csBinPath);
  689. if (eErrPath != Error_Succeed)
  690. {
  691. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Load, GetBasePath failed (%d).",eErrPath);
  692. return Error_Param;
  693. }
  694. LogWarn(Severity_Low, Error_Unexpect, ContactlessCard_UserErrorCode_RootInfo, m_adapterInfo.adapterFilePath.GetData());
  695. if (Error_Succeed != LoadUpAdapterLibrary()) {
  696. errMsg = "非接读卡器加载厂商适配器失败!请检查root.ini配置是否正确。";
  697. LogWarn(Severity_Middle, Error_Unexpect, ContactlessCard_UserErrorCode_DllLoadFailed, errMsg.GetData());
  698. return Error_DevLoadFileFailed;
  699. }
  700. do{
  701. l_beginTime = SP::Module::Comm::RVCGetTickCount();
  702. hr = m_hDevHelper->DevOpen(m_adapterInfo.GetPortInt(), m_adapterInfo.GetBaudrateInt());
  703. l_endTime = SP::Module::Comm::RVCGetTickCount();
  704. if (hr == Error_Succeed)
  705. {
  706. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::DevOpen").setCostTime(l_endTime - l_beginTime)("ContactlessCard DevOpen succ , dwPort:%d, dwBaudRate:%d", m_adapterInfo.GetPortInt(), m_adapterInfo.GetBaudrateInt());
  707. SetDevInitFlag();
  708. ZeroMemory(m_devCatInfo.szModel, sizeof(m_devCatInfo.szModel));
  709. ZeroMemory(m_devCatInfo.szType, sizeof(m_devCatInfo.szType));
  710. ZeroMemory(m_devCatInfo.szVendor, sizeof(m_devCatInfo.szVendor));
  711. l_beginTime = SP::Module::Comm::RVCGetTickCount();
  712. eErrDev = m_hDevHelper->GetDevCategory(m_devCatInfo);
  713. l_endTime = SP::Module::Comm::RVCGetTickCount();
  714. if(eErrDev == Error_Succeed)
  715. {
  716. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::GetDevCategory").setCostTime(l_endTime - l_beginTime)("OpenDevice::GetDevCategory");
  717. m_adapterInfo.FulfillCategoryInfo(m_devCatInfo);
  718. }
  719. else
  720. {
  721. SetErrorAndLog(eErrDev, MEC_DEVAPI_RF_GetDevCategory, "DevAdapter::GetDevCategory", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  722. return Error_DevCommFailed;
  723. }
  724. if (!LoadCMBPrint(csBinPath))
  725. {
  726. errMsg = CSimpleStringA::Format("Contactless 启动失败:Load CMBPrint failed.");
  727. LogWarn(Severity_Middle, Error_Unexpect, ContactlessCard_UserErrorCode_DllLoadFailed, errMsg.GetData());
  728. return Error_DevLoadFileFailed;
  729. }
  730. initTries = 0;
  731. break;
  732. } else {
  733. //DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("ContactlessCard DevOpen failed ,重试:%d, dwPort:%d, dwBaudRate:%d", initTries, m_adapterInfo.GetPortInt(), m_adapterInfo.GetBaudrateInt());
  734. CSimpleStringA errmsg = CSimpleStringA::Format("ContactlessCard DevOpen failed ,重试:%d, dwPort:%d, dwBaudRate:%d", initTries, m_adapterInfo.GetPortInt(), m_adapterInfo.GetBaudrateInt());
  735. SetErrorAndLog(hr, MEC_DEVAPI_RF_DevOpen, "DevAdapter::DevOpen", __FUNCTION__, false, l_endTime - l_beginTime, "", errmsg.GetData());
  736. //DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("ContactlessCard 启动失败:DevOpen failed.重试:%d", initTries);
  737. initTries++;
  738. }
  739. } while (initTries < INIT_TRY_NUM);
  740. if (initTries != 0)
  741. {
  742. if (m_bOpened) {
  743. m_hDevHelper->DevClose();
  744. SetDevInitFlag(false);
  745. }
  746. errMsg = CSimpleStringA::Format("非接读卡器启动失败,have tried %d times!!!", initTries);
  747. LogWarn(Severity_Middle, Error_Unexpect, ContactlessCard_UserErrorCode_DevOpen_Failed, errMsg.GetData());
  748. return Error_DevCommFailed;
  749. }
  750. else
  751. {
  752. m_devInit = true;
  753. LogWarn(Severity_Low, Error_Unexpect, ContactlessCard_UserErrorCode_DevOpen_Success, "非接读卡器打开成功");
  754. return Error_Succeed;
  755. }
  756. }
  757. int CContactlessCardFSM::Initial()
  758. {
  759. if (!m_bOpened) {
  760. m_bNeedReset = false;
  761. return 1;//故障模式
  762. }
  763. return 0;
  764. }
  765. bool CContactlessCardFSM::GetDevStatus(bool bPrint)
  766. {
  767. int getDevInfoCount = 0;
  768. long l_beginTime, l_endTime;
  769. ErrorCodeEnum eErr;
  770. do{
  771. l_beginTime = SP::Module::Comm::RVCGetTickCount();
  772. eErr = m_hDevHelper->GetDevStatus(devStatus);
  773. l_endTime = SP::Module::Comm::RVCGetTickCount();
  774. //if (bPrint)
  775. // DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetDevStatus eMedia:%d, eErr:%d", devStatus.eMediaPos, eErr);
  776. if (Error_Succeed == eErr) {
  777. if (bPrint) {
  778. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::GetDevStatus").setCostTime(l_endTime - l_beginTime)("GetDevStatus eMedia:%d", devStatus.eMediaPos);
  779. }
  780. return true;
  781. }
  782. else
  783. {
  784. //DevErrorInfo devErrInfo;
  785. //m_hDevHelper->GetLastErr(devErrInfo);
  786. //DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetDevStatus, errMsg:%s",devErrInfo.szErrMsg);
  787. if (bPrint) {
  788. SetErrorAndLog(eErr, MEC_DEVAPI_RF_GetDevStatus, "DevAdapter::GetDevStatus", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  789. }
  790. getDevInfoCount++;
  791. Sleep(3000);
  792. }
  793. } while (getDevInfoCount < GET_DEV_STATUS_COUNT);
  794. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("get devstatus to reset");
  795. eErr = m_hDevHelper->Reset();
  796. Sleep(MAX_RESET_TIMEROUT);
  797. if (eErr == Error_Succeed)
  798. {
  799. eErr = m_hDevHelper->GetDevStatus(devStatus);
  800. if (eErr == Error_Succeed && devStatus.eMediaPos == CI_MEDIA_PRESENT)
  801. {
  802. }
  803. }
  804. return false;
  805. }
  806. int CContactlessCardFSM::Reset()
  807. {
  808. LOG_FUNCTION();
  809. ErrorCodeEnum eErr;
  810. long l_beginTime, l_endTime;
  811. l_beginTime = SP::Module::Comm::RVCGetTickCount();
  812. eErr = m_hDevHelper->Reset();
  813. l_endTime = SP::Module::Comm::RVCGetTickCount();
  814. if (eErr == Error_Succeed)
  815. {
  816. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::Reset").setCostTime(l_endTime - l_beginTime)("Reset succ");
  817. l_beginTime = SP::Module::Comm::RVCGetTickCount();
  818. eErr = m_hDevHelper->GetDevStatus(devStatus);
  819. l_endTime = SP::Module::Comm::RVCGetTickCount();
  820. if (Error_Succeed == eErr)
  821. {
  822. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::GetDevStatus").setCostTime(l_endTime - l_beginTime)("Reset::GetDevStatus,eMedia:%d", devStatus.eMediaPos);
  823. return 0;
  824. }
  825. else{
  826. SetErrorAndLog(eErr, MEC_DEVAPI_RF_GetDevStatus, "DevAdapter::GetDevStatus", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  827. return 2;
  828. }
  829. }
  830. else
  831. {
  832. SetErrorAndLog(eErr, MEC_DEVAPI_RF_Reset, "DevAdapter::Reset", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  833. return 1;
  834. }
  835. }
  836. int CContactlessCardFSM::InternalAcceptCard()
  837. {
  838. LOG_FUNCTION();
  839. int acceptTries = 0, err = 0;
  840. m_bWaitingAccept = true;
  841. DWORD64 dwStart = SP::Module::Comm::RVCGetTickCount();
  842. DWORD64 dwEnd = dwStart;
  843. do {
  844. if (m_bExit) {
  845. m_bCancelAccept = true;
  846. break;
  847. }
  848. if (m_bCancelAccept) {
  849. err = 3;
  850. goto Err;
  851. }
  852. if (m_bWaitAccepteMore) {
  853. acceptTries = 0;
  854. m_bWaitAccepteMore = false;
  855. dwEnd = dwStart = SP::Module::Comm::RVCGetTickCount();
  856. }
  857. if (GetDevStatus(false)) {
  858. if (devStatus.eMediaPos == CI_MEDIA_RF) {
  859. LogEvent(Severity_Middle, LOG_EVT_CONTACTLESS_CARD_OP, "Contactless card op.");
  860. acceptTries = 0;
  861. goto Err;
  862. } else {
  863. acceptTries++;
  864. Sleep(ACCEPT_TRY_INTERVAL);
  865. }
  866. } else {
  867. err = 1;
  868. goto Err;
  869. }
  870. dwEnd = SP::Module::Comm::RVCGetTickCount();
  871. } while (dwEnd - dwStart <= 55 * 1000);
  872. err = 2;
  873. Err:
  874. m_bExit = false;
  875. m_bWaitingAccept = false;
  876. if (m_bCancelAccept && err != 1)
  877. {
  878. if (GetDevStatus())
  879. {
  880. if (devStatus.eMediaPos == CI_MEDIA_PRESENT)
  881. {
  882. err = 4;
  883. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("cancel eject......");
  884. }
  885. }
  886. else
  887. err = 2;
  888. }
  889. return err;
  890. }
  891. int FindHexCharPosition(LPBYTE data, BYTE hexChar, int len)
  892. {
  893. int notExist = -1,ret = 1,pos = 0;
  894. for (; pos < len; ++pos)
  895. {
  896. BYTE high = (*(data+pos))&0xf0;
  897. BYTE low = (*(data+pos))&0x0f;
  898. if ((high>>4) != hexChar)
  899. ret++;
  900. else
  901. return ret;
  902. if (low != hexChar)
  903. ret++;
  904. else
  905. return ret;
  906. }
  907. ret = notExist;
  908. return ret;
  909. }
  910. int CContactlessCardFSM::AcceptCard(SpReqAnsContext<ContactlessCardService_Insert_Req, ContactlessCardService_Insert_Ans>::Pointer ctx)
  911. {
  912. LOG_FUNCTION();
  913. long l_beginTime, l_endTime;
  914. ctx->Ans.ICType = 0;
  915. m_pCardProcess->DataInit();
  916. LogEvent(Severity_Middle,LOG_EVT_CONTACTLESS_CARD_GREEN_ON,"ContactCard green on");
  917. m_bWaitAccepteMore = false;
  918. int rc = InternalAcceptCard();
  919. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("InternalAcceptCard ret:%d", rc);
  920. LogEvent(Severity_Middle,LOG_EVT_CONTACTLESS_CARD_GREEN_OFF,"ContactCard green off");
  921. if (rc == 0) {
  922. if (ctx != NULL)
  923. {
  924. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("insert error_succeed");
  925. //FetchCard evt;
  926. //evt.status = 3;//oilyang@20181210 用于通知卡机取消插卡
  927. //SpSendBroadcast(m_pEntity->GetFunction(), SP_MSG_OF(FetchCard), SP_MSG_SIG_OF(FetchCard), evt);
  928. ctx->Ans.ICData = "";
  929. int activeCardType;
  930. //int retICData = m_pCardProcess->DetectAndReadICData(CARD_MACHINE_RFIC, m_hDevHelper, "A000000333", activeCardType);
  931. //oilyang@20201014 add emv card support
  932. int retDetectAndRead = -1;
  933. if (!ctx->Req.aid.IsNullOrEmpty())
  934. {
  935. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("front business provide aid:[%s]",(const char*)ctx->Req.aid);
  936. CAutoArray<CSimpleStringA> aidReq;
  937. aidReq.Init(1);
  938. aidReq[0] = ctx->Req.aid;
  939. l_beginTime = SP::Module::Comm::RVCGetTickCount();
  940. retDetectAndRead = m_pCardProcess->DetectAndReadICData(CARD_MACHINE_RFIC, m_hDevHelper, aidReq, activeCardType);
  941. l_endTime = SP::Module::Comm::RVCGetTickCount();
  942. }
  943. else {
  944. l_beginTime = SP::Module::Comm::RVCGetTickCount();
  945. retDetectAndRead = m_pCardProcess->DetectAndReadICData(CARD_MACHINE_RFIC, m_hDevHelper, m_aidList, activeCardType);
  946. l_endTime = SP::Module::Comm::RVCGetTickCount();
  947. }
  948. if (retDetectAndRead < 0)
  949. {
  950. // -1和-2是上电或APDU交互失败,功能集循环调用
  951. if (retDetectAndRead == -1){
  952. if (!ctx->Req.reserved1.IsNullOrEmpty() && ctx->Req.reserved1.Compare("P") == 0) {
  953. SetErrorAndLog(Error_Unexpect, MEC_DEVAPI_RF_ActiveContactlessICCard, "DevAdapter::ActiveContactlessICCard", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  954. }
  955. ctx->Answer(Error_Interact, GetAlarmDEC());
  956. }
  957. else if (retDetectAndRead == -2){
  958. if (!ctx->Req.reserved1.IsNullOrEmpty() && ctx->Req.reserved1.Compare("P") == 0) {
  959. SetErrorAndLog(Error_Unexpect, MEC_DEVAPI_RF_RFTypeABCommand, "DevAdapter::RFTypeABCommand", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  960. }
  961. ctx->Answer(Error_Interact, GetAlarmDEC());
  962. }else if (retDetectAndRead == -3){
  963. if (!ctx->Req.reserved1.IsNullOrEmpty() && ctx->Req.reserved1.Compare("P") == 0) {
  964. SetErrorAndLog(Error_Unexpect, MEC_DEVAPI_RF_RFTypeABCommand, "DevAdapter::RFTypeABCommand", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  965. }
  966. ctx->Answer(Error_Interact, GetAlarmDEC());
  967. }
  968. return 2;
  969. }
  970. ctx->Ans.t2Account = ctx->Ans.ICData = "";
  971. ICData track2(false,0x57,0x00);
  972. ErrorCodeEnum eErr = Error_Unexpect;
  973. string t2ICAccount(""),t2ICCardSerial(""),t2ICCVC(""),t2ICTrack2(""),cardType;
  974. if (m_pCardProcess->FindTagValue(TAG_VECTOR_IC,track2,false,0) == -1)
  975. {
  976. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("no track2 data in ic");
  977. l_beginTime = SP::Module::Comm::RVCGetTickCount();
  978. eErr = m_hDevHelper->HaltCard();
  979. l_endTime = SP::Module::Comm::RVCGetTickCount();
  980. if(Error_Succeed != eErr){
  981. if (!ctx->Req.reserved1.IsNullOrEmpty() && ctx->Req.reserved1.Compare("P") == 0) {
  982. SetErrorAndLog(eErr, MEC_DEVAPI_RF_HaltCard, "DevAdapter::HaltCard", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  983. }
  984. }
  985. ctx->Answer(Error_Interact);//can't find track2,retry 20150128
  986. }
  987. else
  988. {
  989. int pos = FindHexCharPosition(track2.value, 0x0d, track2.lenth);
  990. char *pICTrack2 = new char[128];
  991. ZeroMemory(pICTrack2, 128);
  992. HexBuf2StrBuf(track2.value, &pICTrack2, track2.lenth);
  993. pICTrack2[37] = '\0';
  994. char *ddd = new char[128];
  995. memset(ddd, 0, 128);
  996. memcpy(ddd, pICTrack2, pos - 1);
  997. t2ICTrack2 = pICTrack2;
  998. t2ICAccount = (char*)ddd;//oiltest
  999. LogWarn(Severity_Low, Error_Succeed, ContactlessCard_UserErrorCode_ReadAccount, CSimpleStringA::Format("split pos:%d, card acount:%s,%s"
  1000. , pos, t2ICAccount.substr(0, 6).c_str(), t2ICAccount.substr(t2ICAccount.length() - 4, 4).c_str()));
  1001. ctx->Ans.ICData = ctx->Ans.t2Account = t2ICAccount.c_str();
  1002. ctx->Ans.ICType = 4;
  1003. ctx->Ans.status = 0;
  1004. delete[]ddd;
  1005. delete[]pICTrack2;
  1006. //m_hDevHelper->DeactContactlessICCard();
  1007. }
  1008. ctx->Answer(Error_Succeed);
  1009. }
  1010. }
  1011. else if(rc == 2)
  1012. {
  1013. if (ctx != NULL) {
  1014. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("AcceptCard, insert timeout");
  1015. ctx->Answer(Error_TimeOut);
  1016. }
  1017. }
  1018. else if(rc == 3 || rc == 4)
  1019. {
  1020. if (ctx != NULL)
  1021. {
  1022. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("AcceptCard, insert cancel");
  1023. ctx->Answer(Error_Cancel);
  1024. }
  1025. }else
  1026. {
  1027. //oilyang@20221212
  1028. //actully,we reach here only when calling GetDevStatus failed
  1029. //we have ContactlessCard AND 卡机,no need to throw Error_Unexpect here
  1030. if (ctx != NULL)
  1031. ctx->Answer(Error_DevNotAvailable);
  1032. }
  1033. return rc;
  1034. }
  1035. static CSimpleStringA GetStrData(TrackInfo trackInfo)
  1036. {
  1037. //LOG_FUNCTION();
  1038. CSimpleStringA strRet;
  1039. switch (trackInfo.eStatus) {
  1040. case CI_DATA_OK:
  1041. strRet = (char*)trackInfo.data;
  1042. break;
  1043. case CI_DATA_INVALID:
  1044. strRet = "无效数据";
  1045. break;
  1046. //case CI_DATA_MISSING:
  1047. default:
  1048. strRet = "数据丢失";
  1049. }
  1050. return strRet;
  1051. }
  1052. int CContactlessCardFSM::SplitTrack2(CSimpleStringA pTrack2,Track2Data &decodeData)
  1053. {
  1054. LOG_FUNCTION();
  1055. int dataLen = strlen(pTrack2);
  1056. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("<SplitTrack2>, pTrack2.len:%d", dataLen);
  1057. if (pTrack2.GetLength() == 0) {
  1058. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2J1A")("<SplitTrack2>, pTrack2.len=0");
  1059. return -1;
  1060. }
  1061. switch(dataLen)
  1062. {
  1063. case 28:
  1064. decodeData.t2Region = CSimpleString(pTrack2,4);
  1065. decodeData.t2Account = pTrack2.SubString(4,8);
  1066. decodeData.t2CardSerial = pTrack2.SubString(14,8);//oilyang for 8 onecard
  1067. decodeData.t2CVC = pTrack2.SubString(22,6);
  1068. decodeData.t2ExpireDate = "";
  1069. break;
  1070. case 31:
  1071. decodeData.t2Account = CSimpleString(pTrack2,16);
  1072. decodeData.t2CardSerial = pTrack2.SubString(16,1);
  1073. decodeData.t2CVC = pTrack2.SubString(17,6);
  1074. decodeData.t2Region = pTrack2.SubString(23,4);
  1075. decodeData.t2ExpireDate = pTrack2.SubString(27,4);
  1076. break;
  1077. case 25://AE Card
  1078. decodeData.t2Account = CSimpleString(pTrack2, 15);
  1079. decodeData.t2CardSerial = pTrack2.SubString(15, 1);
  1080. decodeData.t2CVC = pTrack2.SubString(16, 5);
  1081. decodeData.t2ExpireDate = pTrack2.SubString(21, 4);
  1082. decodeData.t2Region = "";
  1083. break;
  1084. case 38:
  1085. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("<SplitTrack2>, pTrack2.len=38 Not implemented ");
  1086. break;
  1087. default:
  1088. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("<SplitTrack2>, pTrack2.len=%d Not implemented ", dataLen);
  1089. return -1;
  1090. }
  1091. decodeData.status = 0;
  1092. return 0;
  1093. }
  1094. int CContactlessCardFSM::PreOnline(SpReqAnsContext<ContactlessCardService_PreOnline_Req,ContactlessCardService_PreOnline_Ans>::Pointer ctx)
  1095. {
  1096. LOG_FUNCTION();
  1097. long l_beginTime, l_endTime;
  1098. m_pCardProcess->DataInit();
  1099. m_pCardProcess->SplitBusinessData(ctx->Req.businessData,ctx->Req.businessData.GetLength());
  1100. m_pCardProcess->SplitBusinessData("DF690101",strlen("DF690101"));
  1101. int activeCardType;
  1102. //oilyang@20201014 add emv card support
  1103. int retDetectAndRead = -1;
  1104. ICData aidFromBus(false, 0x4f, 0x00);
  1105. if (m_pCardProcess->FindTagValue(TAG_VECTOR_BUS, aidFromBus, false, 0) == -1)
  1106. {
  1107. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("the front BusinessData han't provide aid data.");
  1108. retDetectAndRead = m_pCardProcess->DetectAndReadICData(CARD_MACHINE_RFIC, m_hDevHelper, m_aidList, activeCardType);
  1109. }
  1110. else {
  1111. char* pAIDTmp = new char[64];
  1112. memset(pAIDTmp, 0, 64);
  1113. HexBuf2StrBuf(aidFromBus.value, &pAIDTmp, aidFromBus.lenth);
  1114. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("<PreOnline>, the aid is[%s],len:%d .", pAIDTmp, strlen(pAIDTmp));
  1115. CAutoArray<CSimpleString> preAIDs;
  1116. preAIDs.Init(1);
  1117. preAIDs[0] = (CSimpleStringA)pAIDTmp;
  1118. l_beginTime = SP::Module::Comm::RVCGetTickCount();
  1119. retDetectAndRead = m_pCardProcess->DetectAndReadICData(CARD_MACHINE_RFIC, m_hDevHelper, preAIDs, activeCardType);
  1120. l_endTime = SP::Module::Comm::RVCGetTickCount();
  1121. if (pAIDTmp != NULL)
  1122. delete[]pAIDTmp;
  1123. }
  1124. if (retDetectAndRead < 0)
  1125. {
  1126. // -1和-2是上电或APDU交互失败,功能集循环调用
  1127. if (retDetectAndRead == -1){
  1128. if (!ctx->Req.reserved1.IsNullOrEmpty() && ctx->Req.reserved1.Compare("P") == 0) {
  1129. SetErrorAndLog(Error_Unexpect, MEC_DEVAPI_RF_ActiveContactlessICCard, "DevAdapter::ActiveContactlessICCard", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  1130. }
  1131. ctx->Answer(Error_Interact, GetAlarmDEC());
  1132. }
  1133. else if (retDetectAndRead == -2){
  1134. if (!ctx->Req.reserved1.IsNullOrEmpty() && ctx->Req.reserved1.Compare("P") == 0) {
  1135. SetErrorAndLog(Error_Unexpect, MEC_DEVAPI_RF_RFTypeABCommand, "DevAdapter::RFTypeABCommand", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  1136. }
  1137. ctx->Answer(Error_Interact, GetAlarmDEC());
  1138. }else if (retDetectAndRead == -3){
  1139. if (!ctx->Req.reserved1.IsNullOrEmpty() && ctx->Req.reserved1.Compare("P") == 0) {
  1140. SetErrorAndLog(Error_Unexpect, MEC_DEVAPI_RF_RFTypeABCommand, "DevAdapter::RFTypeABCommand", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  1141. }
  1142. ctx->Answer(Error_Interact, GetAlarmDEC());
  1143. }
  1144. return 0;
  1145. }
  1146. //if (m_cardType == CI_CARDTYPE_IC)
  1147. //{
  1148. // ProcessRestrict();
  1149. // CardholderVerify();
  1150. m_pCardProcess->TermRiskManage();
  1151. CSimpleStringA taaResult;
  1152. BYTE bt9f27 = 0;
  1153. int retTAA = m_pCardProcess->TermActionAnalyze(CARD_MACHINE_RFIC,m_hDevHelper,taaResult,true,m_bCDA,bt9f27);
  1154. if (retTAA != 0) {
  1155. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("<PreOnline>, TermActionAnalyze , retTAA:%d, taaResult:%s", retTAA, taaResult.GetData());
  1156. }
  1157. switch(retTAA)
  1158. {//to be added oiltest 20140929
  1159. case -1: //some data may be wrong
  1160. break;
  1161. case 1: //terminal trans
  1162. break;
  1163. case 2: //to do trans end "TransEnd"
  1164. break;
  1165. default:
  1166. break;
  1167. }
  1168. ctx->Ans.result = taaResult;
  1169. if (ctx->Ans.result.GetLength() == 0)
  1170. {
  1171. ctx->Answer(Error_Succeed);
  1172. return 0;
  1173. }
  1174. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("<PreOnline>, term action analyze result[%s]",(const char*)ctx->Ans.result);
  1175. string tmpResult, actionType, result = "", baseICData = "";
  1176. tmpResult = ctx->Ans.result;
  1177. char *pSomeICData = new char[1024];
  1178. ZeroMemory(pSomeICData, 1024);
  1179. int lenRet = m_pCardProcess->ConstructARQCData(tmpResult.substr(6, 4).c_str(), m_pDataToARQC, pSomeICData);
  1180. baseICData = pSomeICData;
  1181. if (pSomeICData != NULL)
  1182. delete[]pSomeICData;
  1183. char arqcLen[8];
  1184. ZeroMemory(arqcLen,sizeof(arqcLen));
  1185. //TODO: CrossPlaform [Gifur@2025729]
  1186. #ifdef RVC_OS_WIN
  1187. itoa(lenRet, arqcLen, 10);
  1188. #else
  1189. sprintf(arqcLen, "%d", lenRet);
  1190. #endif // RVC_OS_WIN
  1191. ICData appExpiryDate(false,0x5f,0x24);
  1192. if (m_pCardProcess->FindTagValue(TAG_VECTOR_IC,appExpiryDate,false,0) == -1)
  1193. {
  1194. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2J1B")("can't find expire date");
  1195. return 0;
  1196. }
  1197. char *pExpireDate = new char[12];
  1198. ZeroMemory(pExpireDate,12);
  1199. HexBuf2StrBuf(appExpiryDate.value,&pExpireDate,appExpiryDate.lenth);
  1200. ICData track2(false,0x57,0x00),ICCardSerial(false,0x5f,0x34);
  1201. ErrorCodeEnum eErr = Error_Unexpect;
  1202. string t2ICAccount(""),t2ICCardSerial(""),t2ICCVC(""),t2ICTrack2(""),cardType("0");
  1203. char *pICCardSerial = new char[4];
  1204. ZeroMemory(pICCardSerial,4);
  1205. if (m_pCardProcess->FindTagValue(TAG_VECTOR_IC,ICCardSerial,false) == -1)
  1206. {
  1207. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2J1B")("can't find card serial.");
  1208. }
  1209. else
  1210. {
  1211. HexBuf2StrBuf(ICCardSerial.value,&pICCardSerial,ICCardSerial.lenth);
  1212. }
  1213. if (m_pCardProcess->FindTagValue(TAG_VECTOR_IC,track2,false,0) == -1)
  1214. {
  1215. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("no track2 data in ic");
  1216. }
  1217. else
  1218. {
  1219. int pos = FindHexCharPosition(track2.value,0x0d,track2.lenth);
  1220. char *pICTrack2 = new char[128];
  1221. ZeroMemory(pICTrack2,128);
  1222. HexBuf2StrBuf(track2.value,&pICTrack2,track2.lenth);
  1223. pICTrack2[37] = '\0';
  1224. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("<PreOnline>, split pos:%d", pos);
  1225. char *ddd = new char[40];
  1226. ZeroMemory(ddd,40);
  1227. memcpy(ddd,pICTrack2,pos-1);
  1228. char icTrack2Data[128];
  1229. ZeroMemory(icTrack2Data,sizeof(icTrack2Data));
  1230. Track2Data track2Data;
  1231. track2Data.status = 0;
  1232. track2Data.t2Account = "";
  1233. cmdDecodeMag2(pICTrack2,icTrack2Data);
  1234. if (SplitTrack2(icTrack2Data,track2Data) == 0)
  1235. {
  1236. t2ICAccount = track2Data.t2Account;
  1237. //t2ICCardSerial = track2Data.t2CardSerial;
  1238. t2ICCVC = track2Data.t2CVC;
  1239. t2ICTrack2 = pICTrack2;
  1240. }
  1241. //}
  1242. if (strnicmp(track2Data.t2Account,ddd,strlen(ddd)))
  1243. {
  1244. t2ICCVC = "";
  1245. t2ICTrack2 = pICTrack2;
  1246. t2ICAccount = (char*)ddd;
  1247. 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());
  1248. }
  1249. t2ICCardSerial = pICCardSerial;
  1250. delete []ddd;
  1251. delete []pICTrack2;
  1252. }
  1253. //80 1e 80 0008 328ab54bfc986b85 07010103a0b000010a010000000000754048769000
  1254. if (m_pCardProcess->GetP1() == 0x1) {
  1255. actionType = "ARQC";
  1256. }
  1257. else {
  1258. actionType = "";
  1259. }
  1260. //【55域】
  1261. // 基本域:
  1262. // 9F26 8b 应用密文AC
  1263. // 9F27 1b 密文信息数据
  1264. // 9F10 max.32b 发卡行应用数据IAD
  1265. // 9F37 4b 不可预知数
  1266. // 9F36 2b 应用交易计数器ATC
  1267. // 95 5b 终端验证结果TVR
  1268. // 9A 3cn 交易日期(6位有效数字,YYMMDD)
  1269. // 9C 1cn 交易类型(2位有效数字)
  1270. // 9F02 6cn 授权金额(12位有效数字)
  1271. // 5F2A 2cn 交易货币代码(3位有效数字)
  1272. // 82 2b 应用交互特征AIP
  1273. // 9F1A 2cn 终端国家代码(3位有效数字)
  1274. // 9F03 6cn 其他金额(12位有效数字)
  1275. // 9F33 3b 终端性能 "E0C900"
  1276. // 可选域:
  1277. //添加9F26,9F27,9F10,9F33的数据
  1278. char *pCID = new char[4];
  1279. ZeroMemory(pCID, 4);
  1280. HexBuf2StrBuf(&bt9f27, &pCID, 1);
  1281. char *pIssueBankLen = new char[4];
  1282. ZeroMemory(pIssueBankLen, 4);
  1283. int len9f10 = tmpResult.length() - 26 - 4;
  1284. int lenHigh, lenLow;
  1285. len9f10 = len9f10 / 2;
  1286. lenHigh = len9f10 / 16;
  1287. lenLow = len9f10 % 16;
  1288. BYTE bt9f10;
  1289. bt9f10 = (lenHigh << 4) + lenLow;
  1290. HexBuf2StrBuf(&bt9f10, &pIssueBankLen, 1);
  1291. baseICData += "9F2608" + tmpResult.substr(10, 16) + "9F2701" + pCID + "9F10" + pIssueBankLen + tmpResult.substr(26, tmpResult.length() - 26 - 4) + "9F3303" + "E0C900";
  1292. result = "ACTION," + actionType + "|" + "ATCCODE," + tmpResult.substr(6, 4) + "|" + "ARQCCODE," + tmpResult.substr(10, 16) + "|"
  1293. + "MAC," + tmpResult.substr(26, tmpResult.length() - 26 - 4) + "|" + "ARQCSIZE," + string(arqcLen) + "|"
  1294. + "ARQCDATA," + m_pDataToARQC + "|EXPIREDATE," + pExpireDate + "|T2ACCOUNT," + t2ICAccount + "|T2CARDSERIAL," + t2ICCardSerial
  1295. + "|T2CVC," + t2ICCVC + "|T2TRACK2," + t2ICTrack2 + "|CARDCAT," + cardType + "|ICTAGS," + baseICData;
  1296. ctx->Ans.result = result.c_str();
  1297. string txtresult = "";
  1298. txtresult = "ACTION," + actionType + "|" + "ATCCODE," + tmpResult.substr(6, 4) + "|" + "ARQCCODE," + tmpResult.substr(10, 16) + "|"
  1299. + "MAC," + tmpResult.substr(26, tmpResult.length() - 26 - 4) + "|" + "ARQCSIZE," + string(arqcLen) + "|"
  1300. + "ARQCDATA," + m_pDataToARQC + "|T2ACCOUNT(F6)," + t2ICAccount.substr(0, 6) + "|T2ACCOUNT(L4)," + t2ICAccount.substr(t2ICAccount.length() - 4, 4)
  1301. + "|T2CARDSERIAL(len)," + t2ICCardSerial + "|CARDCAT," + cardType;
  1302. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("data to host(less)[%s],baseICData length:%d", txtresult.c_str(), baseICData.length());
  1303. if (m_pDataToARQC != NULL)
  1304. {
  1305. delete []m_pDataToARQC;
  1306. m_pDataToARQC = NULL;
  1307. }
  1308. ctx->Answer(Error_Succeed);
  1309. return 0;
  1310. }
  1311. int CContactlessCardFSM::PostOnline(SpReqAnsContext<ContactlessCardService_PostOnline_Req,ContactlessCardService_PostOnline_Ans>::Pointer ctx)
  1312. {
  1313. LOG_FUNCTION();
  1314. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("post online data[%s]",(LPCTSTR)ctx->Req.data);
  1315. m_pCardProcess->SplitOnlineReplyData(ctx->Req.data,strlen(ctx->Req.data));
  1316. int issBnkAuth = m_pCardProcess->IssueBankAuth(CARD_MACHINE_RFIC,m_hDevHelper);
  1317. CSimpleStringA csTransEnd;
  1318. if (issBnkAuth == 0)
  1319. {
  1320. int transEnd = m_pCardProcess->TransEnd(CARD_MACHINE_RFIC,m_hDevHelper,m_bCDA);
  1321. if (transEnd == 0)
  1322. csTransEnd = "TRANSEND,0";
  1323. else if (transEnd == 1)
  1324. csTransEnd = "TRANSEND,1";
  1325. }
  1326. else
  1327. csTransEnd = "TRANSEND,1";
  1328. ctx->Ans.result = csTransEnd;
  1329. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("PostOnline, issBnkAuth:%d, csTransEnd:%s", issBnkAuth, csTransEnd.GetData());
  1330. ctx->Answer(Error_Succeed);
  1331. return 0;
  1332. }
  1333. int CContactlessCardFSM::EjectCard(SpReqAnsContext<ContactlessCardService_Eject_Req,ContactlessCardService_Eject_Ans>::Pointer ctx)
  1334. {
  1335. LOG_FUNCTION();
  1336. m_pCardProcess->DataInit();
  1337. int ret = 0;
  1338. DWORD dwStart = SP::Module::Comm::RVCGetTickCount();
  1339. DWORD dwEnd = dwStart;
  1340. while(1)
  1341. {
  1342. if (m_bExit)
  1343. {
  1344. ret = 2;
  1345. break;
  1346. }
  1347. dwEnd = SP::Module::Comm::RVCGetTickCount();
  1348. if ((dwEnd-dwStart) > 58*1000)
  1349. {
  1350. ret = 2;
  1351. break;
  1352. }
  1353. ErrorCodeEnum eErr = m_hDevHelper->GetDevStatus(devStatus);
  1354. if (eErr == Error_Succeed)
  1355. {
  1356. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("EjectCard, devStatus.eMedia %d",devStatus.eMediaPos);
  1357. if (devStatus.eMediaPos == CI_MEDIA_RF || devStatus.eMediaPos == CI_MEDIA_NOTPRESENT)
  1358. {
  1359. if (devStatus.eMediaPos == CI_MEDIA_NOTPRESENT)
  1360. ret = 0;
  1361. else if (devStatus.eMediaPos == CI_MEDIA_RF)
  1362. ret = 1;
  1363. break;
  1364. }
  1365. }
  1366. Sleep(100);
  1367. }
  1368. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("eject, ret:%d",ret);
  1369. if (ctx != NULL)
  1370. ctx->Answer(Error_Succeed);
  1371. return ret;
  1372. }
  1373. int CContactlessCardFSM::WaitFetchingCard()
  1374. {
  1375. LOG_FUNCTION();
  1376. int waitTries = 0;
  1377. LogEvent(Severity_Middle,LOG_EVT_CONTACTLESS_CARD_GREEN_ON,"ContactCard(fetch) warning on");
  1378. do {
  1379. if (GetDevStatus(false)){
  1380. if (devStatus.eMediaPos == CI_MEDIA_RF){
  1381. Sleep(WAIT_INTERVAL);
  1382. waitTries++;
  1383. }
  1384. else if (devStatus.eMediaPos == CI_MEDIA_NOTPRESENT){
  1385. waitTries = 0;
  1386. LogEvent(Severity_Middle,LOG_EVT_CONTACTLESS_CARD_GREEN_OFF,"ContactCard(fetch) warning off");
  1387. return 0;
  1388. }
  1389. }else
  1390. {
  1391. LogEvent(Severity_Middle,LOG_EVT_CONTACTLESS_CARD_GREEN_OFF,"ContactCard(fetch) warning off");
  1392. return 1;
  1393. }
  1394. }while (waitTries < WAIT_TRY_NUM);
  1395. LogEvent(Severity_Middle,LOG_EVT_CONTACTLESS_CARD_GREEN_OFF,"ContactCard(fetch) warning off");
  1396. return 2;
  1397. }
  1398. int CContactlessCardFSM::QueryCardInfo(SpReqAnsContext<ContactlessCardService_QueryCardInfo_Req, ContactlessCardService_QueryCardInfo_Ans>::Pointer ctx)
  1399. {
  1400. RFICReaderStatus devStatus;
  1401. long l_beginTime, l_endTime;
  1402. l_beginTime = SP::Module::Comm::RVCGetTickCount();
  1403. ErrorCodeEnum eErr = m_hDevHelper->GetDevStatus(devStatus);
  1404. l_endTime = SP::Module::Comm::RVCGetTickCount();
  1405. if (eErr != Error_Succeed)
  1406. {
  1407. SetErrorAndLog(eErr, MEC_DEVAPI_RF_GetDevStatus, "DevAdapter::GetDevStatus", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  1408. ctx->Answer(Error_Unexpect);
  1409. return 1;
  1410. }
  1411. int ret = 0;
  1412. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::GetDevStatus").setCostTime(l_endTime - l_beginTime)("QueryCardInfo, eMedia pos:%d",devStatus.eMediaPos);
  1413. switch(devStatus.eMediaPos)
  1414. {
  1415. //case CI_MEDIA_IC:
  1416. // ret = 2;
  1417. // break;
  1418. //case CI_MEDIA_NOT_IC:
  1419. // ret = 3;
  1420. // break;
  1421. case CI_MEDIA_RF:
  1422. ret = 4;
  1423. break;
  1424. case CI_MEDIA_NOTPRESENT:
  1425. default:
  1426. ret = 0;
  1427. break;
  1428. }
  1429. ctx->Ans.position = ret;
  1430. ctx->Answer(Error_Succeed);
  1431. return ret;
  1432. }
  1433. bool CContactlessCardFSM::LoadCMBPrint(CSimpleStringA csBinPath)
  1434. {
  1435. if (cmdDecodeEx == NULL) {
  1436. CSimpleStringA csCMBPrint("");
  1437. //TODO: CrossPlaform [Gifur@2025730]
  1438. #ifdef RVC_OS_WIN
  1439. csCMBPrint = "CMBPrint.dll";
  1440. csCMBPrint = csBinPath + SPLIT_SLASH_STR + csCMBPrint;
  1441. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("cmbpath %s", (const char*)csCMBPrint);
  1442. HMODULE hr = LoadLibraryA(csCMBPrint);
  1443. if (hr == NULL)
  1444. {
  1445. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2J18")("Load CMBPrint failed(%d).", hr);
  1446. return false;
  1447. }
  1448. if ((cmdDecodeMag2 = (lpCMBdecodeMag2)GetProcAddress(hr, "CMBdecodeMag2")) == NULL)
  1449. {
  1450. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2J18")("Get Mag2 address failed.");
  1451. return false;
  1452. }
  1453. if ((cmdDecodeEx = (lpCMBdecodeEx)GetProcAddress(hr, "CMBdecodeEx")) == NULL)
  1454. {
  1455. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2J18")("Get Mag23Ex address failed.");
  1456. cmdDecodeMag2 = NULL;
  1457. return false;
  1458. }
  1459. #else
  1460. csCMBPrint = "libCMBPrint.so";
  1461. csCMBPrint = csBinPath + "/" + csCMBPrint;
  1462. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("cmbpath %s", (const char*)csCMBPrint);
  1463. void* hr = NULL;
  1464. hr = dlopen(csCMBPrint, RTLD_LAZY);
  1465. if (hr == NULL)
  1466. {
  1467. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2J18")("Load CMBPrint failed(%s).", dlerror());
  1468. return false;
  1469. }
  1470. //pfunc_unpack = (PF_unpack)dlsym(hLib, "_Z6unpackPcS_i");
  1471. if ((cmdDecodeMag2 = (lpCMBdecodeMag2)dlsym(hr, "CMBdecodeMag2")) == NULL)
  1472. {
  1473. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2J18")("Get Mag2 address failed.");
  1474. return false;
  1475. }
  1476. if ((cmdDecodeEx = (lpCMBdecodeEx)dlsym(hr, "CMBdecodeEx")) == NULL)
  1477. {
  1478. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2J18")("Get Mag23Ex address failed.");
  1479. cmdDecodeMag2 = NULL;
  1480. return false;
  1481. }
  1482. #endif
  1483. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Load %s succ.", (const char*)csCMBPrint);
  1484. }
  1485. return true;
  1486. }
  1487. void CContactlessCardFSM::GetCardProcessLastErr(ErrorCodeEnum& eErrCode, CSimpleStringA& ApiName, CSimpleStringA& alarmMsg, CSimpleStringA& csErrMsgWithReturnCode)
  1488. {
  1489. if (m_pCardProcess == NULL) {
  1490. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetCardProcessLastErr m_pCardProcess is null");
  1491. eErrCode = Error_Null;
  1492. ApiName = "";
  1493. alarmMsg = "";
  1494. csErrMsgWithReturnCode = "";
  1495. return;
  1496. }
  1497. ErrorCodeEnum lastErrCode = Error_Succeed;
  1498. CSimpleStringA lastErrMsg = "";
  1499. CSimpleStringA lastApiName = "";
  1500. m_pCardProcess->getCardAssistLastErr(lastErrCode, lastErrMsg, lastApiName);
  1501. const CSimpleStringA alarmMsgStr = CSimpleStringA::Format("{\"Function\":\"%s\", \"DevApi\":\"%s\", \"ReturnCode\":\"%s\", \"Msg\":\"%s\", \"Context\":\"%s\"}"
  1502. , __FUNCTION__, lastApiName.GetData(), SpStrError(lastErrCode), lastErrMsg.GetData(), "");
  1503. std::map<std::string, std::string> msgInfo;
  1504. msgInfo["ReturnCode"] = SpStrError(lastErrCode);
  1505. msgInfo["ErrMsg"] = lastErrMsg.GetData();
  1506. msgInfo["Context"] = "";
  1507. std::pair<bool, std::string> strResult;
  1508. strResult = generateJsonStr(msgInfo);
  1509. CSimpleStringA csErrMsgWithReturnCodeStr = strResult.second.c_str();
  1510. eErrCode = lastErrCode;
  1511. ApiName = lastApiName;
  1512. alarmMsg = alarmMsgStr.GetData();
  1513. csErrMsgWithReturnCode = csErrMsgWithReturnCodeStr.GetData();
  1514. }
  1515. DWORD CContactlessCardFSM::GetFsmStateErrCode()
  1516. {
  1517. int state = GetFSMState();
  1518. switch (state)
  1519. {
  1520. case 2:
  1521. return ContactlessCard_UserErrorCode_PROCESS_IDLE;
  1522. case 4:
  1523. return ContactlessCard_UserErrorCode_PROCESS_HOLD;
  1524. case 5:
  1525. return ContactlessCard_UserErrorCode_PROCESS_READ;
  1526. case 6:
  1527. return ContactlessCard_UserErrorCode_PROCESS_EJECT;
  1528. case 7:
  1529. return ContactlessCard_UserErrorCode_PROCESS_WAIT_FETCH;
  1530. case 8:
  1531. return ContactlessCard_UserErrorCode_PROCESS_CAPTURE;
  1532. case 9:
  1533. return ContactlessCard_UserErrorCode_PROCESS_FAULT;
  1534. case 10:
  1535. return ContactlessCard_UserErrorCode_PROCESS_READ_JS;
  1536. case 11:
  1537. return ContactlessCard_UserErrorCode_PROCESS_EJECT_JS;
  1538. default:
  1539. return ContactlessCard_UserErrorCode_EntityInStateCannotProcess;
  1540. }
  1541. }
  1542. void CContactlessCardFSM::QueryHasCardJS(SpReqAnsContext<ContactlessCardService_QueryHasCardJS_Req, ContactlessCardService_QueryHasCardJS_Ans>::Pointer ctx)
  1543. {
  1544. LOG_FUNCTION();
  1545. int ret = 0;
  1546. if (m_hDevHelper == nullptr) {
  1547. ctx->Answer(Error_Unexpect, ContactlessCard_UserErrorCode_DevOpen_Failed);
  1548. }
  1549. else {
  1550. RFICReaderStatus devStatus;
  1551. long l_beginTime, l_endTime;
  1552. l_beginTime = SP::Module::Comm::RVCGetTickCount();
  1553. ErrorCodeEnum eErr = m_hDevHelper->GetDevStatus(devStatus);
  1554. l_endTime = SP::Module::Comm::RVCGetTickCount();
  1555. if (Error_Succeed == eErr)
  1556. {
  1557. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::GetDevStatus").setCostTime(l_endTime - l_beginTime)("QueryInternalHasCardJS::GetDevStatus, eMedia pos:%d", devStatus.eMediaPos);
  1558. //switch (devStatus.eMediaPos)
  1559. //{
  1560. //case CI_MEDIA_RF:
  1561. // ret = 6;
  1562. // break;
  1563. //case CI_MEDIA_NOTPRESENT:
  1564. // ret = 0;
  1565. // break;
  1566. //case CI_MEDIA_IDCARD:
  1567. // ret = 7;
  1568. // break;
  1569. //default:
  1570. // ret = 0;
  1571. // break;
  1572. //}
  1573. ctx->Ans.position = (int)devStatus.eMediaPos;
  1574. ctx->Answer(Error_Succeed);
  1575. }
  1576. else
  1577. {
  1578. DWORD dwTmpUserErrCode = SetErrorAndLog(eErr, MEC_DEVAPI_RF_GetDevStatus, "DevAdapter::GetDevStatus", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  1579. ctx->Answer(Error_Unexpect, dwTmpUserErrCode);
  1580. }
  1581. }
  1582. }
  1583. int CContactlessCardFSM::EjectJS(SpReqAnsContext<ContactlessCardService_EjectJS_Req, ContactlessCardService_EjectJS_Ans>::Pointer ctx)
  1584. {
  1585. LOG_FUNCTION();
  1586. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("吐卡开始");
  1587. m_pCardProcess->DataInit();
  1588. int ret = 0;
  1589. int getDevInfoCount = 0;
  1590. DWORD dwStart = SP::Module::Comm::RVCGetTickCount();
  1591. DWORD dwEnd = dwStart;
  1592. LogEvent(Severity_Middle, LOG_EVT_CONTACTLESS_CARD_GREEN_ON, "ContactCard(fetch) warning on");
  1593. while (true)
  1594. {
  1595. dwEnd = SP::Module::Comm::RVCGetTickCount();
  1596. if ((dwEnd - dwStart) > 58 * 1000)
  1597. {
  1598. ret = 1;//超时
  1599. break;
  1600. }
  1601. if (m_bPageExit) {
  1602. ret = 2;
  1603. break;//退到首页
  1604. }
  1605. ErrorCodeEnum eErr = m_hDevHelper->GetDevStatus(devStatus);
  1606. if (eErr == Error_Succeed)
  1607. {
  1608. if (devStatus.eMediaPos == CI_MEDIA_RF || devStatus.eMediaPos == CI_MEDIA_NOTPRESENT)
  1609. {
  1610. if (devStatus.eMediaPos == CI_MEDIA_NOTPRESENT){
  1611. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("EjectCard, devStatus.eMedia %d", devStatus.eMediaPos);
  1612. ret = 0;//取走
  1613. break;
  1614. }
  1615. else if (devStatus.eMediaPos == CI_MEDIA_RF) {
  1616. }
  1617. }
  1618. }
  1619. else {
  1620. //getDevInfoCount++;
  1621. //if (getDevInfoCount % 10 == 0) {
  1622. // DevErrorInfo devErrInfo;
  1623. // m_hDevHelper->GetLastErr(devErrInfo);
  1624. // DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetDevStatus, errMsg:%s", devErrInfo.szErrMsg);
  1625. //}
  1626. }
  1627. Sleep(WAIT_INTERVAL);
  1628. }
  1629. LogEvent(Severity_Middle, LOG_EVT_CONTACTLESS_CARD_GREEN_OFF, "ContactCard(fetch) warning off");
  1630. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("eject return.ret=%d",ret);
  1631. if (ctx != NULL) {
  1632. if (ret == 0) {
  1633. ctx->Answer(Error_Succeed);
  1634. }
  1635. else if(ret == 1 || ret == 2){
  1636. ctx->Answer(Error_Exception, ContactlessCard_UserErrorCode_Forget_Fectch_Card);
  1637. }
  1638. }
  1639. return ret;
  1640. }
  1641. int CContactlessCardFSM::ReadJS(SpReqAnsContext<ContactlessCardService_ReadJS_Req, ContactlessCardService_ReadJS_Ans>::Pointer ctx)
  1642. {
  1643. LOG_FUNCTION();
  1644. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("读卡开始");
  1645. int ret = InternalAcceptCardJS();
  1646. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("InternalAcceptCardJS ret:%d", ret);
  1647. if (ret == 0) {
  1648. //寻卡成功,开始联机读卡
  1649. ret = PreOnlineJS(ctx);
  1650. }
  1651. else if (ret == 1) {
  1652. //非IC卡
  1653. ctx->Answer(Error_Exception, ContactlessCard_UserErrorCode_Read_Not_IC);
  1654. }
  1655. else if (ret == 2) {
  1656. //寻卡超时
  1657. ctx->Answer(Error_Exception, ContactlessCard_UserErrorCode_Read_TimeOut);
  1658. }
  1659. else if (ret == 3 || ret == 4){
  1660. //读卡取消
  1661. ctx->Answer(Error_Exception, ContactlessCard_UserErrorCode_Read_Cancel);
  1662. }
  1663. return 0;
  1664. }
  1665. int CContactlessCardFSM::PostOnlineJS(SpReqAnsContext<ContactlessCardService_PostOnlineJS_Req, ContactlessCardService_PostOnlineJS_Ans>::Pointer ctx)
  1666. {
  1667. LOG_FUNCTION();
  1668. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("(PostOnlineJS) 联机后IC接触处理");
  1669. m_pCardProcess->DataInit();
  1670. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("postOnLine data[%s]", ctx->Req.data.GetData());
  1671. m_pCardProcess->SplitOnlineReplyData(ctx->Req.data, strlen(ctx->Req.data));
  1672. int issBnkAuth = m_pCardProcess->IssueBankAuth(CARD_MACHINE_RFIC, m_hDevHelper);
  1673. CSimpleStringA csTransEnd;
  1674. if (issBnkAuth == 0)
  1675. {
  1676. int transEnd = m_pCardProcess->TransEnd(CARD_MACHINE_RFIC, m_hDevHelper, m_bCDA);
  1677. if (transEnd == 0) {
  1678. csTransEnd = "TRANSEND,0";
  1679. }
  1680. else if (transEnd == 1) {
  1681. csTransEnd = "TRANSEND,1";
  1682. }
  1683. }
  1684. else {
  1685. csTransEnd = "TRANSEND,1";
  1686. }
  1687. ctx->Ans.result = csTransEnd;
  1688. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("<PostOnlineJS>, issBnkAuth:%d, csTransEnd:%s", issBnkAuth, csTransEnd.GetData());
  1689. ctx->Answer(Error_Succeed);
  1690. return 0;
  1691. }
  1692. int CContactlessCardFSM::InternalAcceptCardJS()
  1693. {
  1694. LOG_FUNCTION();
  1695. int err = 0;
  1696. long l_beginTime, l_endTime;
  1697. DWORD64 dwStart = SP::Module::Comm::RVCGetTickCount();
  1698. DWORD64 dwEnd = dwStart;
  1699. ErrorCodeEnum eErr = Error_Succeed;
  1700. LogEvent(Severity_Middle, LOG_EVT_CONTACTLESS_CARD_GREEN_ON, "ContactCard green on");
  1701. int timeOutResult = 0;
  1702. do {
  1703. if (m_bCancelRead) {
  1704. err = 3;//取消读卡
  1705. break;
  1706. }
  1707. if (m_bPageExit) {
  1708. err = 4;//退到首页,取消读卡
  1709. break;
  1710. }
  1711. l_beginTime = SP::Module::Comm::RVCGetTickCount();
  1712. eErr = m_hDevHelper->GetDevStatus(devStatus);
  1713. l_endTime = SP::Module::Comm::RVCGetTickCount();
  1714. if (eErr == Error_Succeed) {
  1715. if (devStatus.eMediaPos == CI_MEDIA_RF) {
  1716. LogEvent(Severity_Middle, LOG_EVT_CONTACTLESS_CARD_OP, "Contactless card op.");
  1717. int activeCardType;
  1718. l_beginTime = SP::Module::Comm::RVCGetTickCount();
  1719. bool bIC = m_pCardProcess->DetectIfICCard(CARD_MACHINE_RFIC, m_hDevHelper, activeCardType);
  1720. l_endTime = SP::Module::Comm::RVCGetTickCount();
  1721. if (bIC) {
  1722. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("InternalAcceptCardJS::DetectIfICCard activeCardType=%d", activeCardType);
  1723. if (activeCardType == 'A' || activeCardType == 'B' || activeCardType == 'M') {
  1724. err = 0;//探测到IC卡
  1725. }
  1726. else {
  1727. err = 1;//非IC卡
  1728. }
  1729. break;
  1730. }
  1731. else {
  1732. //探测失败,继续循环
  1733. err = 2;
  1734. timeOutResult = 1;
  1735. Sleep(ACCEPT_TRY_INTERVAL);
  1736. }
  1737. }
  1738. else {
  1739. //无卡,继续循环
  1740. err = 2;
  1741. timeOutResult = 3;
  1742. Sleep(ACCEPT_TRY_INTERVAL);
  1743. }
  1744. }
  1745. else {
  1746. //查询卡机状态失败,继续循环
  1747. err = 2;
  1748. timeOutResult = 2;
  1749. Sleep(ACCEPT_TRY_INTERVAL);
  1750. }
  1751. dwEnd = SP::Module::Comm::RVCGetTickCount();
  1752. } while (dwEnd - dwStart <= 55 * 1000);
  1753. //超时报错
  1754. if (err == 2) {
  1755. if (timeOutResult == 1) {
  1756. SetErrorAndLog(Error_Unexpect, MEC_DEVAPI_RF_ActiveContactlessICCard, "DevAdapter::ActiveContactlessICCard", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  1757. }
  1758. else if (timeOutResult == 2) {
  1759. SetErrorAndLog(Error_Unexpect, MEC_DEVAPI_RF_GetDevStatus, "DevAdapter::GetDevStatus", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  1760. }
  1761. else {
  1762. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("InternalAcceptCardJS No IC card found ");
  1763. }
  1764. }
  1765. LogEvent(Severity_Middle, LOG_EVT_CONTACTLESS_CARD_GREEN_OFF, CSimpleStringA::Format("ContactCard green off,err=%d", err).GetData());
  1766. return err;
  1767. }
  1768. int CContactlessCardFSM::PreOnlineJS(SpReqAnsContext<ContactlessCardService_ReadJS_Req, ContactlessCardService_ReadJS_Ans>::Pointer ctx)
  1769. {
  1770. LOG_FUNCTION();
  1771. long l_beginTime, l_endTime;
  1772. m_pCardProcess->DataInit();
  1773. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("<PreOnlineJS>, aid[%s], bus data[%s]", ctx->Req.aid.GetData(),ctx->Req.businessData.GetData());
  1774. m_pCardProcess->SplitBusinessData(ctx->Req.businessData, ctx->Req.businessData.GetLength());
  1775. m_pCardProcess->SplitBusinessData("DF690101", strlen("DF690101"));
  1776. int activeCardType;
  1777. //oilyang@20201014 add emv card support
  1778. int retDetectAndRead = -1;
  1779. ICData aidFromBus(false, 0x4f, 0x00);
  1780. if (m_pCardProcess->FindTagValue(TAG_VECTOR_BUS, aidFromBus, false, 0) == -1)
  1781. {
  1782. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("the front BusinessData han't provide aid data.");
  1783. retDetectAndRead = m_pCardProcess->DetectAndReadICData(CARD_MACHINE_RFIC, m_hDevHelper, m_aidList, activeCardType);
  1784. }
  1785. else {
  1786. char* pAIDTmp = new char[64];
  1787. memset(pAIDTmp, 0, 64);
  1788. HexBuf2StrBuf(aidFromBus.value, &pAIDTmp, aidFromBus.lenth);
  1789. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("<PreOnlineJS>, the aid is[%s],len:%d .", pAIDTmp, strlen(pAIDTmp));
  1790. CAutoArray<CSimpleString> preAIDs;
  1791. preAIDs.Init(1);
  1792. preAIDs[0] = (CSimpleStringA)pAIDTmp;
  1793. l_beginTime = SP::Module::Comm::RVCGetTickCount();
  1794. retDetectAndRead = m_pCardProcess->DetectAndReadICData(CARD_MACHINE_RFIC, m_hDevHelper, preAIDs, activeCardType);
  1795. l_endTime = SP::Module::Comm::RVCGetTickCount();
  1796. if (pAIDTmp != NULL) {
  1797. delete[]pAIDTmp;
  1798. }
  1799. }
  1800. if (retDetectAndRead < 0)
  1801. {
  1802. ctx->Ans.icState = 0;//调用失败
  1803. if (retDetectAndRead == -1) {
  1804. DWORD dwTmpUserErrCode = SetErrorAndLog(Error_Unexpect, MEC_DEVAPI_RF_ActiveContactlessICCard, "DevAdapter::ActiveContactlessICCard", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  1805. ctx->Answer(Error_Exception, dwTmpUserErrCode);
  1806. }
  1807. else if (retDetectAndRead == -2) {
  1808. DWORD dwTmpUserErrCode = SetErrorAndLog(Error_Unexpect, MEC_DEVAPI_RF_RFTypeABCommand, "DevAdapter::RFTypeABCommand", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  1809. ctx->Answer(Error_Exception, dwTmpUserErrCode);
  1810. }
  1811. else if (retDetectAndRead == -3) {
  1812. DWORD dwTmpUserErrCode = SetErrorAndLog(Error_Unexpect, MEC_DEVAPI_RF_RFTypeABCommand, "DevAdapter::RFTypeABCommand", __FUNCTION__, false, l_endTime - l_beginTime, "", "");
  1813. ctx->Answer(Error_Exception, dwTmpUserErrCode);
  1814. }
  1815. return -1;
  1816. }
  1817. m_pCardProcess->TermRiskManage();
  1818. CSimpleStringA taaResult;
  1819. BYTE bt9f27 = 0;
  1820. int retTAA = m_pCardProcess->TermActionAnalyze(CARD_MACHINE_RFIC, m_hDevHelper, taaResult, true, m_bCDA, bt9f27);
  1821. if (retTAA != 0) {
  1822. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("<PreOnlineJS>,TermActionAnalyze retTAA:%d, taaResult:%s", retTAA, taaResult.GetData());
  1823. }
  1824. switch (retTAA)
  1825. {//to be added oiltest 20140929
  1826. case -1: //some data may be wrong
  1827. break;
  1828. case 1: //terminal trans
  1829. break;
  1830. case 2: //to do trans end "TransEnd"
  1831. break;
  1832. default:
  1833. break;
  1834. }
  1835. ctx->Ans.result = taaResult;
  1836. if (ctx->Ans.result.GetLength() == 0)
  1837. {
  1838. ctx->Ans.icState = 0;
  1839. ctx->Answer(Error_Succeed);
  1840. return 0;
  1841. }
  1842. string tmpResult, actionType, result = "", baseICData = "";
  1843. tmpResult = ctx->Ans.result;
  1844. char* pSomeICData = new char[1024];
  1845. ZeroMemory(pSomeICData, 1024);
  1846. int lenRet = m_pCardProcess->ConstructARQCData(tmpResult.substr(6, 4).c_str(), m_pDataToARQC, pSomeICData);
  1847. baseICData = pSomeICData;
  1848. if (pSomeICData != NULL) {
  1849. delete[]pSomeICData;
  1850. }
  1851. char arqcLen[8];
  1852. ZeroMemory(arqcLen, sizeof(arqcLen));
  1853. //TODO: CrossPlaform [Gifur@2025729]
  1854. #ifdef RVC_OS_WIN
  1855. itoa(lenRet, arqcLen, 10);
  1856. #else
  1857. sprintf(arqcLen, "%d", lenRet);
  1858. #endif // RVC_OS_WIN
  1859. ICData track2(false, 0x57, 0x00), ICCardSerial(false, 0x5f, 0x34), appExpiryDate(false, 0x5f, 0x24);
  1860. string t2ICAccount(""), t2ICCardSerial(""), t2ICCVC(""), t2ICTrack2(""), cardType("0"),t2ICExpireDate("");
  1861. char* pExpireDate = new char[12];//获取ic有效期
  1862. ZeroMemory(pExpireDate, 12);
  1863. if (m_pCardProcess->FindTagValue(TAG_VECTOR_IC, appExpiryDate, false, 0) == -1)
  1864. {
  1865. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2J1B")("can't find expire date");
  1866. }
  1867. else {
  1868. HexBuf2StrBuf(appExpiryDate.value, &pExpireDate, appExpiryDate.lenth);
  1869. t2ICExpireDate = pExpireDate;
  1870. }
  1871. delete[] pExpireDate;
  1872. char* pICCardSerial = new char[4];//获取ic序号
  1873. ZeroMemory(pICCardSerial, 4);
  1874. if (m_pCardProcess->FindTagValue(TAG_VECTOR_IC, ICCardSerial, false) == -1)
  1875. {
  1876. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2J1B")("can't find card serial.");
  1877. }
  1878. else
  1879. {
  1880. HexBuf2StrBuf(ICCardSerial.value, &pICCardSerial, ICCardSerial.lenth);
  1881. t2ICCardSerial = pICCardSerial;
  1882. }
  1883. delete[] pICCardSerial;
  1884. char* pICTrack2 = new char[128];//获取等效磁条2
  1885. ZeroMemory(pICTrack2, 128);
  1886. if (m_pCardProcess->FindTagValue(TAG_VECTOR_IC, track2, false, 0) == -1)
  1887. {
  1888. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("no track2 data in ic");
  1889. }
  1890. else
  1891. {
  1892. HexBuf2StrBuf(track2.value, &pICTrack2, track2.lenth);
  1893. t2ICTrack2 = pICTrack2;
  1894. int pos = FindHexCharPosition(track2.value, 0x0d, track2.lenth);
  1895. pICTrack2[37] = '\0';
  1896. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("<PreOnlineJS>, split pos:%d", pos);
  1897. char* ddd = new char[40];
  1898. ZeroMemory(ddd, 40);
  1899. memcpy(ddd, pICTrack2, pos - 1);
  1900. char icTrack2Data[128];
  1901. ZeroMemory(icTrack2Data, sizeof(icTrack2Data));
  1902. Track2Data track2Data;
  1903. track2Data.status = 0;
  1904. track2Data.t2Account = "";
  1905. cmdDecodeMag2(pICTrack2, icTrack2Data);
  1906. if (SplitTrack2(icTrack2Data, track2Data) == 0)
  1907. {
  1908. t2ICAccount = track2Data.t2Account;
  1909. //t2ICCardSerial = track2Data.t2CardSerial;
  1910. t2ICCVC = track2Data.t2CVC;
  1911. }
  1912. if (strnicmp(track2Data.t2Account, ddd, strlen(ddd)))
  1913. {
  1914. t2ICCVC = "";
  1915. t2ICAccount = (char*)ddd;
  1916. 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());
  1917. }
  1918. delete[]ddd;
  1919. LogWarn(Severity_Low, Error_Succeed, ContactlessCard_UserErrorCode_ReadAccount, CSimpleStringA::Format("split pos:%d, card acount:%s,%s"
  1920. , pos, t2ICAccount.substr(0, 6).c_str(), t2ICAccount.substr(t2ICAccount.length() - 4, 4).c_str()));//读到的卡号
  1921. }
  1922. delete[]pICTrack2;
  1923. //80 1e 80 0008 328ab54bfc986b85 07010103a0b000010a010000000000754048769000
  1924. if (m_pCardProcess->GetP1() == 0x1) {
  1925. actionType = "ARQC";
  1926. }
  1927. else {
  1928. actionType = "";
  1929. }
  1930. //【55域】
  1931. // 基本域:
  1932. // 9F26 8b 应用密文AC
  1933. // 9F27 1b 密文信息数据
  1934. // 9F10 max.32b 发卡行应用数据IAD
  1935. // 9F37 4b 不可预知数
  1936. // 9F36 2b 应用交易计数器ATC
  1937. // 95 5b 终端验证结果TVR
  1938. // 9A 3cn 交易日期(6位有效数字,YYMMDD)
  1939. // 9C 1cn 交易类型(2位有效数字)
  1940. // 9F02 6cn 授权金额(12位有效数字)
  1941. // 5F2A 2cn 交易货币代码(3位有效数字)
  1942. // 82 2b 应用交互特征AIP
  1943. // 9F1A 2cn 终端国家代码(3位有效数字)
  1944. // 9F03 6cn 其他金额(12位有效数字)
  1945. // 9F33 3b 终端性能 "E0C900"
  1946. // 可选域:
  1947. //添加9F26,9F27,9F10,9F33的数据
  1948. char* pCID = new char[4];
  1949. ZeroMemory(pCID, 4);
  1950. HexBuf2StrBuf(&bt9f27, &pCID, 1);
  1951. char* pIssueBankLen = new char[4];
  1952. ZeroMemory(pIssueBankLen, 4);
  1953. int len9f10 = tmpResult.length() - 26 - 4;
  1954. int lenHigh, lenLow;
  1955. len9f10 = len9f10 / 2;
  1956. lenHigh = len9f10 / 16;
  1957. lenLow = len9f10 % 16;
  1958. BYTE bt9f10;
  1959. bt9f10 = (lenHigh << 4) + lenLow;
  1960. HexBuf2StrBuf(&bt9f10, &pIssueBankLen, 1);
  1961. baseICData += "9F2608" + tmpResult.substr(10, 16) + "9F2701" + pCID + "9F10" + pIssueBankLen + tmpResult.substr(26, tmpResult.length() - 26 - 4) + "9F3303" + "E0C900";
  1962. //result = "ACTION," + actionType + "|" + "ATCCODE," + tmpResult.substr(6, 4) + "|" + "ARQCCODE," + tmpResult.substr(10, 16) + "|"
  1963. // + "MAC," + tmpResult.substr(26, tmpResult.length() - 26 - 4) + "|" + "ARQCSIZE," + string(arqcLen) + "|"
  1964. // + "ARQCDATA," + m_pDataToARQC + "|EXPIREDATE," + pExpireDate + "|T2ACCOUNT," + t2ICAccount + "|T2CARDSERIAL," + t2ICCardSerial
  1965. // + "|T2CVC," + t2ICCVC + "|T2TRACK2," + t2ICTrack2 + "|CARDCAT," + cardType + "|ICTAGS," + baseICData;
  1966. //json格式返回
  1967. std::map<std::string, std::string> msgInfo;
  1968. msgInfo["ACTION"] = actionType.c_str();
  1969. msgInfo["ATC_CODE"] = tmpResult.substr(6, 4).c_str();
  1970. msgInfo["ARQC_CODE"] = tmpResult.substr(10, 16).c_str();
  1971. msgInfo["MAC"] = tmpResult.substr(26, tmpResult.length() - 26 - 4).c_str();
  1972. CSimpleStringA arqcLenStr = arqcLen;
  1973. msgInfo["ARQC_SIZE"] = arqcLenStr.GetData();
  1974. CSimpleStringA arqcData = m_pDataToARQC;
  1975. msgInfo["ARQC_DATA"] = arqcData.GetData();
  1976. msgInfo["T2TRACK2_DATA"] = t2ICTrack2.c_str();
  1977. msgInfo["EXPIRE_DATE"] = t2ICExpireDate.c_str();
  1978. msgInfo["T2CARD_SERIAL"] = t2ICCardSerial.c_str();
  1979. msgInfo["CARD_CAT"] = cardType.c_str();
  1980. msgInfo["IC_TAGS"] = baseICData.c_str();
  1981. std::pair<bool, std::string> strResult;
  1982. strResult = generateJsonStr(msgInfo);
  1983. result = strResult.second.c_str();
  1984. ctx->Ans.result = result.c_str();
  1985. ctx->Ans.icState = 1;
  1986. //DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("data to host result=%s,len=%d", result.c_str(),result.length());
  1987. string txtresult = "ACTION," + actionType + "|" + "ATCCODE," + tmpResult.substr(6, 4) + "|" + "ARQCCODE," + tmpResult.substr(10, 16) + "|"
  1988. + "MAC," + tmpResult.substr(26, tmpResult.length() - 26 - 4) + "|" + "ARQCSIZE," + string(arqcLen) + "|ARQCDATA, " + m_pDataToARQC + "|"
  1989. + "T2TRACK2(len)," + CSimpleStringA::Format("%d", t2ICTrack2.length()).GetData() + "|"
  1990. + "EXPIREDATE(len)," + CSimpleStringA::Format("%d", t2ICExpireDate.length()).GetData() + "|"
  1991. + "T2CARDSERIAL(len), " + CSimpleStringA::Format("%d", t2ICCardSerial.length()).GetData() + "|"
  1992. + "CARDCAT, " + cardType + "|"
  1993. + "ICTAGS, " + CSimpleStringA::Format("%d", baseICData.length()).GetData();
  1994. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("data to host(less)[%s]", txtresult.c_str());
  1995. if (pCID != NULL)
  1996. delete[]pCID;
  1997. if (pIssueBankLen != NULL)
  1998. delete[]pIssueBankLen;
  1999. if (m_pDataToARQC != NULL)
  2000. {
  2001. delete[]m_pDataToARQC;
  2002. m_pDataToARQC = NULL;
  2003. }
  2004. ctx->Answer(Error_Succeed);
  2005. return 0;
  2006. }
  2007. void CContactlessCardFSM::OnStateTrans(int iSrcState, int iDstState)
  2008. {
  2009. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("trans from %s to %s", GetStateName(iSrcState), GetStateName(iDstState));
  2010. }