CardIssuerFSM.h 43 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423
  1. #ifndef __CARD_ISSUER_FSM_H
  2. #define __CARD_ISSUER_FSM_H
  3. #pragma once
  4. #include "SpFSM.h"
  5. #include "CardIssuerStand_server_g.h"
  6. //#include "GUIConsole_client_g.h"
  7. #include "HeartBeat_client_g.h"
  8. #include "AccessAuthorization_client_g.h"
  9. #include "DevFSMCommBase.hpp"
  10. #include "CardIssuerClass.h"
  11. #include "CardAssist.h"
  12. #include "ICDataElement.h"
  13. #include "IHttpFunc.h"
  14. #include "json/json.h"
  15. #define REFLECTION(var) #var
  16. using namespace CardIssuerStand;
  17. //using namespace GUIConsole;
  18. using namespace HeartBeat;
  19. using namespace AccessAuthorization;
  20. enum EvtType
  21. {
  22. USER_EVT_TEST = EVT_USER+1,
  23. USER_EVT_QUIT,
  24. USER_EVT_INIT,
  25. USER_EVT_INITFINISHED,
  26. USER_EVT_ACCEPT,
  27. USER_EVT_ACCEPT_CANCEL,
  28. USER_EVT_ACCEPTFINISHED,
  29. USER_EVT_ISSUE,
  30. USER_EVT_ISSUE_FINISHED,
  31. USER_EVT_EJECT,
  32. USER_EVT_CAPTURE,
  33. USER_EVT_EJECTFINISHED,
  34. USER_EVT_WAITFINISHED,
  35. USER_EVT_CAPTUREFINISHED,
  36. USER_EVT_WAITFETCHINGTIMEOUT,
  37. USER_EVT_PREONLINE,
  38. USER_EVT_POSTONLINE,
  39. USER_EVT_PREONLINEFINISHED,
  40. USER_EVT_POSTONLINEFINISHED,
  41. USER_EVT_RESET,
  42. USER_EVT_RESETFINISHED,
  43. USER_EVT_EXIT,
  44. USER_EVT_READ,
  45. USER_EVT_READ_FINISHED,
  46. USER_EVT_WRITE,
  47. USER_EVT_WRITE_FINISHED,
  48. USER_EVT_GET_MATERIAL_EX,
  49. USER_EVT_SET_MATERIAL_EX,
  50. USER_EVT_ISSUE_EX,
  51. USER_EVT_ISSUE_EX_FINISHED,
  52. USER_EVT_SAM_IC,
  53. USER_EVT_SAM_IC_FINISHED,
  54. USER_EVT_BACK_TO_INIT,
  55. //新定义JS状态机事件枚举
  56. USER_EVT_JS_CAPTURE = EVT_USER + 38,
  57. USER_EVT_JS_CAPTURE_FINISHED,
  58. USER_EVT_JS_EJECT,
  59. USER_EVT_JS_EJECT_FINISHED,
  60. USER_EVT_JS_POSTONLINE,
  61. USER_EVT_JS_POSTONLINE_FINISHED,
  62. USER_EVT_JS_ISSUE_FROM_BOX,
  63. USER_EVT_JS_ISSUE_FROM_BOX_FINISHED,
  64. USER_EVT_QUICK_SELF_CHECK,
  65. USER_EVT_QUICK_SELF_CHECK_FINISHED,
  66. USER_EVT_JS_READ,
  67. USER_EVT_JS_READ_FINISHED,
  68. USER_EVT_JS_INSERT,
  69. USER_EVT_JS_INSERT_FINISHED,
  70. USER_EVT_JS_INSERT_CANCEL,
  71. USER_EVT_EXIT_MIAN_PAGE,
  72. };
  73. enum SAMICCommandType
  74. {
  75. //SAM
  76. SAMICCommand_SAM_Select = 0,
  77. SAMICCommand_SAM_Active,
  78. SAMICCommand_SAM_Deactivate,
  79. SAMICCommand_SAM_WarmReset,
  80. SAMICCommand_SAM_QueryStatus,
  81. SAMICCommand_SAM_Command,
  82. //IC
  83. SAMICCommand_IC_Active = 100,
  84. SAMICCommand_IC_Deactivate,
  85. SAMICCommand_IC_WarmReset,
  86. SAMICCommand_IC_Command,
  87. SAMICCommand_RFIC_Active,
  88. SAMICCommand_RFIC_Deactivate,
  89. SAMICCommand_RFIC_Command,
  90. };
  91. typedef int(*lpCMBdecodeMag2)(char* Mag2Data, char * data);
  92. typedef int(*lpCMBdecodeEx)( char* MagData, char * type, char * data);
  93. typedef int(__stdcall *pfEncryptDukptHSM)(unsigned char* EncryptedData, unsigned char* bdk, unsigned char* curksn, unsigned char* DecryptedData);
  94. typedef int(__stdcall *pfGetEncrypedData)(unsigned char* BDK, unsigned char* KSN, unsigned char*random, unsigned char* result);
  95. class CCardIssuerEntity;
  96. class CCardIssuerFSM;
  97. const int ONE_K = 1024;
  98. const int HOPPER_NUM = 12;
  99. struct Track2Data
  100. {
  101. int status;
  102. CSimpleStringA t2Account;
  103. CSimpleStringA t2Region;
  104. CSimpleStringA t2CardSerial;
  105. CSimpleStringA t2CVC;
  106. CSimpleStringA t2ExpireDate;
  107. };
  108. struct CMBBin
  109. {
  110. CSimpleStringA bin;//6 byte long
  111. bool bIC;//IC:true or mag:false
  112. bool bDC;//debit:true,credit:false
  113. };
  114. struct SCIRecord
  115. {
  116. CSimpleStringA name;
  117. CSimpleStringA remoteMac;
  118. };
  119. class CardInitFinishedEvent : public FSMEvent
  120. {
  121. public:
  122. CardInitFinishedEvent() : FSMEvent(USER_EVT_INITFINISHED){}
  123. ~CardInitFinishedEvent(){}
  124. SpReqAnsContext<CardIssuerStandService_Insert_Req,CardIssuerStandService_Insert_Ans>::Pointer ctx;
  125. protected:
  126. private:
  127. };
  128. class CardAcceptEvent : public FSMEvent
  129. {
  130. public:
  131. CardAcceptEvent() : FSMEvent(USER_EVT_ACCEPT) {}
  132. ~CardAcceptEvent() {}
  133. SpReqAnsContext<CardIssuerStandService_Insert_Req, CardIssuerStandService_Insert_Ans>::Pointer ctx;
  134. virtual void OnUnhandled()
  135. {
  136. if (ctx != NULL)
  137. {
  138. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("card accept unhandled");
  139. ctx->Answer(Error_InvalidState);
  140. }
  141. }
  142. };
  143. class CardIssueEvent : public FSMEvent
  144. {
  145. public:
  146. CardIssueEvent() : FSMEvent(USER_EVT_ISSUE) {}
  147. ~CardIssueEvent() {}
  148. SpReqAnsContext<CardIssuerStandService_Issue_Req, CardIssuerStandService_Issue_Ans>::Pointer ctx;
  149. virtual void OnUnhandled()
  150. {
  151. if (ctx != NULL)
  152. {
  153. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("card issue unhandled");
  154. ctx->Answer(Error_InvalidState);
  155. }
  156. }
  157. };
  158. class CancelAcceptEvent : public FSMEvent
  159. {
  160. public:
  161. CancelAcceptEvent() : FSMEvent(USER_EVT_ACCEPT_CANCEL) {}
  162. ~CancelAcceptEvent() {}
  163. virtual void OnUnhandled()
  164. {
  165. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("card cancel accept unhandled");
  166. }
  167. };
  168. class CardReadEvent : public FSMEvent
  169. {
  170. public:
  171. CardReadEvent() : FSMEvent(USER_EVT_READ) {}
  172. ~CardReadEvent() {}
  173. SpReqAnsContext<CardIssuerStandService_Read_Req, CardIssuerStandService_Read_Ans>::Pointer ctx;
  174. virtual void OnUnhandled()
  175. {
  176. if (ctx != NULL)
  177. {
  178. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("card read unhandled");
  179. ctx->Answer(Error_InvalidState);
  180. }
  181. }
  182. protected:
  183. private:
  184. };
  185. class CardReadFinishedEvent : public FSMEvent
  186. {
  187. public:
  188. CardReadFinishedEvent() : FSMEvent(USER_EVT_READ_FINISHED) {}
  189. ~CardReadFinishedEvent() {}
  190. SpReqAnsContext<CardIssuerStandService_Read_Req, CardIssuerStandService_Read_Ans>::Pointer ctx;
  191. virtual void OnUnhandled()
  192. {
  193. if (ctx != NULL)
  194. {
  195. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("card read unhandled(new)");
  196. }
  197. }
  198. protected:
  199. private:
  200. };
  201. class ResetDeviceEvent : public FSMEvent
  202. {
  203. public:
  204. ResetDeviceEvent() : FSMEvent(USER_EVT_RESET){}
  205. ~ResetDeviceEvent(){}
  206. protected:
  207. private:
  208. };
  209. class ResetFinishedEvent : public FSMEvent
  210. {
  211. public:
  212. ResetFinishedEvent() : FSMEvent(USER_EVT_RESETFINISHED){}
  213. ~ResetFinishedEvent(){}
  214. protected:
  215. private:
  216. };
  217. class PreOnlineEvent : public FSMEvent
  218. {
  219. public:
  220. PreOnlineEvent() : FSMEvent(USER_EVT_PREONLINE){}
  221. ~PreOnlineEvent(){}
  222. SpReqAnsContext<CardIssuerStandService_PreOnline_Req,CardIssuerStandService_PreOnline_Ans>::Pointer ctx;
  223. virtual void OnUnhandled()
  224. {
  225. if (ctx != NULL)
  226. ctx->Answer(Error_InvalidState);
  227. }
  228. protected:
  229. private:
  230. };
  231. class PostOnlineEvent : public FSMEvent
  232. {
  233. public:
  234. PostOnlineEvent() : FSMEvent(USER_EVT_POSTONLINE){}
  235. ~PostOnlineEvent(){}
  236. SpReqAnsContext<CardIssuerStandService_PostOnline_Req,CardIssuerStandService_PostOnline_Ans>::Pointer ctx;
  237. virtual void OnUnhandled()
  238. {
  239. if (ctx != NULL)
  240. ctx->Answer(Error_InvalidState);
  241. }
  242. protected:
  243. private:
  244. };
  245. class CardCaptureEvent : public FSMEvent
  246. {
  247. public:
  248. CardCaptureEvent() : FSMEvent(USER_EVT_CAPTURE){}
  249. ~CardCaptureEvent(){}
  250. SpReqAnsContext<CardIssuerStandService_Capture_Req,CardIssuerStandService_Capture_Ans>::Pointer ctx;
  251. virtual void OnUnhandled()
  252. {
  253. if (ctx != NULL)
  254. ctx->Answer(Error_InvalidState);
  255. }
  256. protected:
  257. private:
  258. };
  259. class CardEjectEvent : public FSMEvent
  260. {
  261. public:
  262. CardEjectEvent() : FSMEvent(USER_EVT_EJECT){}
  263. ~CardEjectEvent(){}
  264. SpReqAnsContext<CardIssuerStandService_Eject_Req,CardIssuerStandService_Eject_Ans>::Pointer ctx;
  265. virtual void OnUnhandled()
  266. {
  267. if (ctx != NULL)
  268. ctx->Answer(Error_InvalidState);
  269. }
  270. protected:
  271. private:
  272. };
  273. class CardWriteEvent : public FSMEvent
  274. {
  275. public:
  276. CardWriteEvent() : FSMEvent(USER_EVT_WRITE){}
  277. ~CardWriteEvent(){}
  278. SpReqAnsContext<CardIssuerStandService_WriteTrack_Req,CardIssuerStandService_WriteTrack_Ans>::Pointer ctx;
  279. virtual void OnUnhandled()
  280. {
  281. if (ctx != NULL)
  282. {
  283. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("card read unhandled");
  284. ctx->Answer(Error_InvalidState);
  285. }
  286. }
  287. protected:
  288. private:
  289. };
  290. class CardWriteFinishedEvent : public FSMEvent
  291. {
  292. public:
  293. CardWriteFinishedEvent() : FSMEvent(USER_EVT_WRITE_FINISHED){}
  294. ~CardWriteFinishedEvent(){}
  295. SpReqAnsContext<CardIssuerStandService_WriteTrack_Req,CardIssuerStandService_WriteTrack_Ans>::Pointer ctx;
  296. virtual void OnUnhandled()
  297. {
  298. if (ctx != NULL)
  299. {
  300. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("card read unhandled(new)");
  301. }
  302. }
  303. protected:
  304. private:
  305. };
  306. class GetMaterialExEvent : public FSMEvent
  307. {
  308. public:
  309. GetMaterialExEvent() : FSMEvent(USER_EVT_GET_MATERIAL_EX) {}
  310. ~GetMaterialExEvent() {}
  311. SpReqAnsContext<CardIssuerStandService_GetMaterialCountEx_Req, CardIssuerStandService_GetMaterialCountEx_Ans>::Pointer ctx;
  312. virtual void OnUnhandled()
  313. {
  314. if (ctx != NULL)
  315. ctx->Answer(Error_InvalidState);
  316. }
  317. protected:
  318. private:
  319. };
  320. class SetMaterialExEvent : public FSMEvent
  321. {
  322. public:
  323. SetMaterialExEvent() : FSMEvent(USER_EVT_SET_MATERIAL_EX){}
  324. ~SetMaterialExEvent(){}
  325. SpReqAnsContext<CardIssuerStandService_SetMaterialCountEx_Req, CardIssuerStandService_SetMaterialCountEx_Ans>::Pointer ctx;
  326. virtual void OnUnhandled()
  327. {
  328. if (ctx != NULL)
  329. ctx->Answer(Error_InvalidState);
  330. }
  331. protected:
  332. private:
  333. };
  334. class CardIssueExEvent : public FSMEvent
  335. {
  336. public:
  337. CardIssueExEvent() : FSMEvent(USER_EVT_ISSUE_EX){}
  338. ~CardIssueExEvent(){}
  339. SpReqAnsContext<CardIssuerStandService_IssueEx_Req, CardIssuerStandService_IssueEx_Ans>::Pointer ctx;
  340. virtual void OnUnhandled()
  341. {
  342. if (ctx != NULL)
  343. {
  344. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("card issue ex unhandled");
  345. ctx->Answer(Error_InvalidState);
  346. }
  347. }
  348. };
  349. class SAMICCommandEvent : public FSMEvent
  350. {
  351. public:
  352. SAMICCommandEvent() : FSMEvent(USER_EVT_SAM_IC){}
  353. ~SAMICCommandEvent(){}
  354. SpReqAnsContext<CardIssuerStandService_SAMICCommand_Req, CardIssuerStandService_SAMICCommand_Ans>::Pointer ctx;
  355. virtual void OnUnhandled()
  356. {
  357. if (ctx != NULL)
  358. {
  359. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("sam/ic unhandled");
  360. ctx->Answer(Error_InvalidState);
  361. }
  362. }
  363. };
  364. #pragma region JS接口 event
  365. //JS接口
  366. class EjectJSEvent : public FSMEvent
  367. {
  368. public:
  369. EjectJSEvent() : FSMEvent(USER_EVT_JS_EJECT) {}
  370. ~EjectJSEvent() {}
  371. SpReqAnsContext<CardIssuerStandService_EjectJS_Req, CardIssuerStandService_EjectJS_Ans>::Pointer ctx;
  372. virtual void OnUnhandled()
  373. {
  374. if (ctx != NULL)
  375. {
  376. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("EjectJS Operate unhandled");
  377. }
  378. }
  379. };
  380. class CaptureJSEvent : public FSMEvent
  381. {
  382. public:
  383. CaptureJSEvent() : FSMEvent(USER_EVT_JS_CAPTURE) {}
  384. ~CaptureJSEvent() {}
  385. SpReqAnsContext<CardIssuerStandService_CaptureJS_Req, CardIssuerStandService_CaptureJS_Ans>::Pointer ctx;
  386. virtual void OnUnhandled()
  387. {
  388. if (ctx != NULL)
  389. {
  390. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("CaptureJS Operate unhandled");
  391. }
  392. }
  393. };
  394. class PostOnlineJSEvent : public FSMEvent
  395. {
  396. public:
  397. PostOnlineJSEvent() : FSMEvent(USER_EVT_JS_POSTONLINE) {}
  398. ~PostOnlineJSEvent() {}
  399. SpReqAnsContext<CardIssuerStandService_PostOnlineJS_Req, CardIssuerStandService_PostOnlineJS_Ans>::Pointer ctx;
  400. virtual void OnUnhandled()
  401. {
  402. if (ctx != NULL)
  403. {
  404. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("PostOnlineJS Operate unhandled");
  405. }
  406. }
  407. };
  408. class IssueFromBoxJSEvent : public FSMEvent
  409. {
  410. public:
  411. IssueFromBoxJSEvent() : FSMEvent(USER_EVT_JS_ISSUE_FROM_BOX) {}
  412. ~IssueFromBoxJSEvent() {}
  413. SpReqAnsContext<CardIssuerStandService_IssueFromBoxJS_Req, CardIssuerStandService_IssueFromBoxJS_Ans>::Pointer ctx;
  414. virtual void OnUnhandled()
  415. {
  416. if (ctx != NULL)
  417. {
  418. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("IssueFromBoxJS Operate unhandled");
  419. }
  420. }
  421. };
  422. class QuickSelfcheckFinishEvent : public FSMEvent
  423. {
  424. public:
  425. QuickSelfcheckFinishEvent() : FSMEvent(USER_EVT_QUICK_SELF_CHECK_FINISHED) {}
  426. ~QuickSelfcheckFinishEvent() {}
  427. protected:
  428. private:
  429. };
  430. class ReadJSEvent : public FSMEvent
  431. {
  432. public:
  433. ReadJSEvent() : FSMEvent(USER_EVT_JS_READ) {}
  434. ~ReadJSEvent() {}
  435. SpReqAnsContext<CardIssuerStandService_ReadJS_Req, CardIssuerStandService_ReadJS_Ans>::Pointer ctx;
  436. virtual void OnUnhandled()
  437. {
  438. if (ctx != NULL)
  439. {
  440. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("ReadJS Operate unhandled");
  441. }
  442. }
  443. };
  444. class InsertJSEvent : public FSMEvent
  445. {
  446. public:
  447. InsertJSEvent() : FSMEvent(USER_EVT_JS_INSERT) {}
  448. ~InsertJSEvent() {}
  449. SpReqAnsContext<CardIssuerStandService_InsertJS_Req, CardIssuerStandService_InsertJS_Ans>::Pointer ctx;
  450. virtual void OnUnhandled()
  451. {
  452. if (ctx != NULL)
  453. {
  454. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("InsertJS Operate unhandled");
  455. }
  456. }
  457. };
  458. class CancelInsertJSEvent : public FSMEvent
  459. {
  460. public:
  461. CancelInsertJSEvent() : FSMEvent(USER_EVT_JS_INSERT_CANCEL) {}
  462. ~CancelInsertJSEvent() {}
  463. virtual void OnUnhandled()
  464. {
  465. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("CancelInsertJS Operate unhandled");
  466. }
  467. };
  468. #pragma endregion JS接口 event
  469. typedef struct EacQueryByEac_X1 {
  470. string xEacNbr;
  471. string xCltNbr;
  472. string xIacNbr;
  473. } EacQueryByEac_X1;
  474. typedef struct CQueryCardTypeReq : CHTTPReq {
  475. struct HEAD {
  476. int xHdrLen;
  477. string xIsuCnl;
  478. string xRtnCod;
  479. }HEAD;
  480. struct BODY {
  481. EacQueryByEac_X1 x1;
  482. }BODY;
  483. int X1Count;
  484. CQueryCardTypeReq() {
  485. X1Count = 1;
  486. }
  487. string ToJson() {
  488. Json::Value allElm,x1Arr;
  489. allElm[REFLECTION(HEAD)][REFLECTION(xHdrLen)] = HEAD.xHdrLen;
  490. allElm[REFLECTION(HEAD)][REFLECTION(xIsuCnl)] = HEAD.xIsuCnl;
  491. allElm[REFLECTION(HEAD)][REFLECTION(xRtnCod)] = HEAD.xRtnCod;
  492. for (int i = 0; i < X1Count; i++) {
  493. Json::Value x1Elm;
  494. Json::FastWriter fwX1Elm;//写入对象
  495. x1Elm[REFLECTION(xEacNbr)] = BODY.x1.xEacNbr.c_str();
  496. x1Elm[REFLECTION(xCltNbr)] = BODY.x1.xCltNbr.c_str();
  497. x1Elm[REFLECTION(xIacNbr)] = BODY.x1.xIacNbr.c_str();
  498. //string x1JsonStr = fwX1Elm.write(x1Elm);
  499. x1Arr[i] = x1Elm;
  500. }
  501. allElm[REFLECTION(BODY)][REFLECTION(EacQueryByEac_X1)] = x1Arr;
  502. Json::FastWriter writer;
  503. string ret = writer.write(allElm);
  504. return ret;
  505. }
  506. } CQueryCardTypeReq;
  507. typedef struct EacQueryByEac_Z1 {
  508. string zEacNbr;
  509. string zEacSts;
  510. string zEacTyp;
  511. string zEacNam;
  512. string zEacNik;
  513. string zEacCod;
  514. string zCltNbr;
  515. string zIacNbr;
  516. string zKeySeq;
  517. string zFndClt;
  518. string zFndIac;
  519. string zFndCpb;
  520. string zFndAtp;
  521. string zFpnClt;
  522. string zFpnIac;
  523. string zCtfCnr;
  524. string zCtfTyp;
  525. string zPsbTag;
  526. string zPsbFac;
  527. string zPsbNbr;
  528. string zPsbCod;
  529. string zPsbSeq;
  530. string zPsbMdm;
  531. string zCvcCod;
  532. string zCvcCd2;
  533. string zCvcIcd;
  534. string zMapBus;
  535. string zMapCnl;
  536. string zMapDpn;
  537. string zMapPwd;
  538. string zMapAut;
  539. string zWrmFlg;
  540. string zBlsFlg;
  541. string zNamFlg;
  542. string zActFlg;
  543. string zSlpFlg;
  544. string zFkcFlg;
  545. string zSnmFlg;
  546. string zWrfAll;
  547. string zWrfNdk;
  548. string zWrfZft;
  549. string zWrfDsk;
  550. string zPayLck;
  551. string zQryTag;
  552. string zFncTag;
  553. string zWdwTag;
  554. string zPayTag;
  555. string zTmpTag;
  556. string zExtTag;
  557. string zCtfTag;
  558. string zMskTag;
  559. string zStfFlg;
  560. string zSlaFlg;
  561. string zBatFlg;
  562. string zAgtFlg;
  563. string zAmgTag;
  564. string zCurTag;
  565. string zImgIdt;
  566. string zGrpFlg;
  567. string zOpnDat;
  568. string zOpnUsr;
  569. string zOpnChk;
  570. string zOpnAut;
  571. string zActDat;
  572. string zClsDat;
  573. string zClsUsr;
  574. string zClsChk;
  575. string zClsAut;
  576. string zDatEft;
  577. string zDatExp;
  578. string zBbkNbr;
  579. string zBrnNbr;
  580. string zBrnMng;
  581. string zCtyCod;
  582. }EacQueryByEac_Z1;
  583. typedef struct CQueryCardTypeRet : CHTTPRet {
  584. struct HEAD {
  585. string xTypCod;
  586. string xHdrLen;
  587. string xSysCod;
  588. string xDskSys;
  589. string xWkeCod;
  590. string xKeyVal;
  591. string xIsuCnl;
  592. string xEncCod;
  593. string xDalCod;
  594. string xCmmTyp;
  595. string xOrgIsu;
  596. string xPreIsu;
  597. string xEntUsr;
  598. string xUsrPwd;
  599. string xIsuDat;
  600. string xIsuTim;
  601. string xMacCod;
  602. string xRtnLvl;
  603. string xRtnCod;
  604. string xDevNbr;
  605. string xTlrNbr;
  606. string xRqsNbr;
  607. string xCmmRsv;
  608. string xDocSiz;
  609. string xItvTms;
  610. string xMsgFlg;
  611. string xAppRsv;
  612. }HEAD;
  613. struct BODY {
  614. EacQueryByEac_Z1 z1;
  615. }BODY;
  616. int Z1Count;
  617. CQueryCardTypeRet() : Z1Count(1) {
  618. }
  619. bool Parse(string strData) {
  620. Json::Value root,tmpZ1;
  621. Json::Reader reader;
  622. Json::Value::UInt index;
  623. if (!reader.parse(strData, root, false))
  624. {
  625. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("reader.parse false");//又不能打印,有什么太大意义?
  626. return false;
  627. }
  628. index = 0;
  629. HEAD.xRtnCod = root["HEAD"][REFLECTION(xRtnCod)].asCString();
  630. if (HEAD.xRtnCod.compare("SUC0000") == 0)
  631. {
  632. tmpZ1 = root["BODY"][REFLECTION(EacQueryByEac_Z1)];
  633. BODY.z1.zPsbMdm = tmpZ1[index][REFLECTION(zPsbMdm)].asCString();
  634. BODY.z1.zEacNbr = tmpZ1[index][REFLECTION(zEacNbr)].asCString();
  635. BODY.z1.zPsbSeq = tmpZ1[index][REFLECTION(zPsbSeq)].asCString();
  636. return true;
  637. }
  638. else
  639. return false;
  640. }
  641. } CQueryCardTypeRet;
  642. typedef struct CRegistSwallowCardReq : CHTTPReq {
  643. string cardNo;
  644. string cardType;
  645. string channel;
  646. string clearInstanceId;
  647. string deviceSciNo;
  648. string bankNo;
  649. string editTime;
  650. string editor;
  651. string fromFlag;
  652. string idKey;
  653. string informType;
  654. string psbCode;
  655. string reasonCode;
  656. string state;
  657. string structId;
  658. string swallowDate;
  659. string swallowTime;
  660. string terminalNo;
  661. string terminalType;
  662. string uuid;
  663. string ToJson() {
  664. Json::Value allElm, x1Arr;
  665. allElm[REFLECTION(cardNo)] = cardNo;
  666. allElm[REFLECTION(deviceSciNo)] = deviceSciNo;
  667. allElm[REFLECTION(reasonCode)] = reasonCode;
  668. allElm[REFLECTION(swallowDate)] = swallowDate;
  669. allElm[REFLECTION(swallowTime)] = swallowTime;
  670. allElm[REFLECTION(terminalNo)] = terminalNo;
  671. allElm[REFLECTION(terminalType)] = terminalType;
  672. Json::FastWriter writer;
  673. string ret = writer.write(allElm);
  674. return ret;
  675. }
  676. } CRegistSwallowCardReq;
  677. typedef struct CRegistSwallowCardRet : CHTTPRet {
  678. struct returnInfo {
  679. string returnCode;
  680. string errorMsg;
  681. }returnInfo;
  682. struct data {
  683. }data;
  684. bool Parse(string strData) {
  685. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)(strData.c_str());
  686. Json::Value root, tmpZ1;
  687. Json::Reader reader;
  688. if (!reader.parse(strData, root, false))
  689. {
  690. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("reader.parse false");//又不能打印,有什么太大意义?
  691. return false;
  692. }
  693. if (!root["returnInfo"].isNull()) {
  694. returnInfo.returnCode = root["returnInfo"][REFLECTION(returnCode)].asCString();
  695. return true;
  696. }
  697. else {
  698. return false;//报文结构不对,解析失败
  699. }
  700. //returnInfo.returnCode = root["returnInfo"][REFLECTION(returnCode)].asCString();
  701. }
  702. } CRegistSwallowCardRet;
  703. // 同步卡库计数到后台服务实体类
  704. struct SyncMaterialCountInfo
  705. {
  706. CSimpleStringA strDeviceNo;
  707. unsigned int dwCardBoxNum;
  708. CAutoArray<bool> arrMaintainFlag;
  709. CAutoArray<CSimpleStringA> arrMaintainer;
  710. CAutoArray<unsigned int> arrMaintainTime;
  711. CAutoArray<CSimpleStringA> arrCardBoxNo;
  712. CAutoArray<CSimpleStringA> arrPsbCode;
  713. CAutoArray<CSimpleStringA> arrPsbName;
  714. CAutoArray<unsigned int> arrCardInit;
  715. CAutoArray<unsigned int> arrCardRemains;
  716. CAutoArray<unsigned int> arrCardIssued;
  717. CAutoArray<unsigned int> arrCardMixed;
  718. CAutoArray<unsigned int> arrCardPercent;
  719. };
  720. struct SyncMaterialCountReq1
  721. {
  722. char TerminalNo[16];
  723. char DeviceNo[16];
  724. char Material[16];
  725. DWORD CardBoxNum;
  726. };
  727. struct SyncMaterialCountReq2
  728. {
  729. bool bMaintain;
  730. char Maintainer[16];
  731. DWORD MaintainTime;
  732. char CardBoxNo[20];
  733. char PsbCode[8];
  734. char PsbName[128];
  735. DWORD CardInit;
  736. DWORD CardRemains;
  737. DWORD CardIssued;
  738. DWORD CardMixed;
  739. DWORD CardPercent;
  740. };
  741. struct SyncMaterialCountHTTPReq : CHTTPReq {
  742. SyncMaterialCountHTTPReq() { m_timeOut = 30; }
  743. SyncMaterialCountReq1 reqInfo;
  744. std::vector<SyncMaterialCountReq2> reqData;
  745. virtual string ToJson() {
  746. Json::Value root;
  747. Json::Value arrayObj;
  748. root["terminalNo"] = reqInfo.TerminalNo;
  749. root["deviceNo"] = reqInfo.DeviceNo;
  750. root["materiel"] = reqInfo.Material;
  751. root["cardBoxNum"] = (int)reqInfo.CardBoxNum;
  752. for (int i = 0; i <= reqInfo.CardBoxNum; i++)
  753. {
  754. Json::Value item;
  755. item["CardBoxNo"] = reqData[i].CardBoxNo;
  756. item["PsbCode"] = reqData[i].PsbCode;
  757. item["PsbName"] = reqData[i].PsbName;
  758. item["CardInit"] = (int)reqData[i].CardInit;
  759. item["CardRemains"] = (int)reqData[i].CardRemains;
  760. item["CardIssued"] = (int)reqData[i].CardIssued;
  761. item["CardMixed"] = (int)reqData[i].CardMixed;
  762. item["CardPercent"] = (int)reqData[i].CardPercent;
  763. item["Maintainer"] = reqData[i].Maintainer;
  764. if (reqData[i].MaintainTime == 0)
  765. item["MaintainTime"] = "";
  766. else {
  767. item["MaintainTime"] = CSmallDateTime::GetNow().ToTimeString().GetData();
  768. //DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("MaintainTime:%d", (DWORD)CSmallDateTime::GetNow());
  769. }
  770. item["bMaintain"] = reqData[i].bMaintain;
  771. arrayObj.append(item);
  772. }
  773. root["cardIssueList"] = arrayObj;
  774. return root.toStyledString();
  775. }
  776. };
  777. struct SyncMaterialCountHTTPRet : CHTTPRet {
  778. string m_retStr;
  779. bool Parse(string strData) {
  780. m_retStr = strData;
  781. return true;
  782. }
  783. };
  784. class CCardIssuerFSM : public CCommDevFSM<CCardIssuerFSM, CardIssuerClass>
  785. {
  786. public:
  787. enum {s0,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10,s11,s14};
  788. BEGIN_FSM_STATE(CCardIssuerFSM)
  789. FSM_STATE_ENTRY(s0,"Init",s0_on_entry,s0_on_exit,s0_on_event)
  790. FSM_STATE_ENTRY(s1,"Initializing",s1_on_entry,s1_on_exit,s1_on_event)
  791. FSM_STATE_ENTRY(s2,"Idle",s2_on_entry,s2_on_exit,s2_on_event)
  792. FSM_STATE_ENTRY(s3,"Accepting",s3_on_entry,s3_on_exit,s3_on_event)
  793. FSM_STATE_ENTRY(s4,"Hold",s4_on_entry,s4_on_exit,s4_on_event)
  794. FSM_STATE_ENTRY(s5,"Reading",s5_on_entry,s5_on_exit,s5_on_event)
  795. FSM_STATE_ENTRY(s6,"Ejecting",s6_on_entry,s6_on_exit,s6_on_event)
  796. FSM_STATE_ENTRY(s7,"WaitFetching",s7_on_entry,s7_on_exit,s7_on_event)
  797. FSM_STATE_ENTRY(s8,"Capturing",s8_on_entry,s8_on_exit,s8_on_event)
  798. FSM_STATE_ENTRY(s9,"Failed",s9_on_entry,s9_on_exit,s9_on_event)
  799. FSM_STATE_ENTRY(s10,"Issuing",s10_on_entry,s10_on_exit,s10_on_event)
  800. FSM_STATE_ENTRY(s11,"Writing",s11_on_entry,s11_on_exit,s11_on_event)
  801. FSM_STATE_ENTRY(s14, "SAMIC", s14_on_entry, s14_on_exit, s14_on_event)
  802. END_FSM_STATE()
  803. BEGIN_FSM_RULE(CCardIssuerFSM,s0)
  804. FSM_RULE_ENTRY(s0, s2, USER_EVT_TEST, 0)
  805. FSM_RULE_ENTRY(s0,s1,USER_EVT_INIT,0)
  806. FSM_RULE_ENTRY(s0, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  807. FSM_RULE_ENTRY(s1,s2,USER_EVT_INITFINISHED,0)
  808. FSM_RULE_ENTRY(s1,s9,USER_EVT_INITFINISHED,1)
  809. FSM_RULE_ENTRY(s1, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  810. FSM_RULE_ENTRY(s2,s3,USER_EVT_ACCEPT,0)
  811. // FSM_RULE_ENTRY(s2,s9,USER_EVT_ACCEPT,1)
  812. FSM_RULE_ENTRY(s2, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  813. FSM_RULE_ENTRY(s2,s10,USER_EVT_ISSUE,0)
  814. FSM_RULE_ENTRY(s2, s10, USER_EVT_ISSUE_EX, 0)
  815. FSM_RULE_ENTRY(s3,s4,USER_EVT_ACCEPTFINISHED,0)
  816. FSM_RULE_ENTRY(s3,s9,USER_EVT_ACCEPTFINISHED,1)
  817. FSM_RULE_ENTRY(s3,s2,USER_EVT_ACCEPTFINISHED,2)
  818. FSM_RULE_ENTRY(s3,s2,USER_EVT_ACCEPTFINISHED,3)
  819. FSM_RULE_ENTRY(s3,s7,USER_EVT_ACCEPTFINISHED,4)
  820. FSM_RULE_ENTRY(s3, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  821. FSM_RULE_ENTRY(s4,s5,USER_EVT_READ,0)
  822. FSM_RULE_ENTRY(s4,s6,USER_EVT_EJECT,0)
  823. FSM_RULE_ENTRY(s4,s6,USER_EVT_EXIT,0)
  824. FSM_RULE_ENTRY(s4,s8,USER_EVT_ACCEPT,0)
  825. FSM_RULE_ENTRY(s4,s8,USER_EVT_EXIT,1)
  826. FSM_RULE_ENTRY(s4,s8,USER_EVT_CAPTURE,0)
  827. FSM_RULE_ENTRY(s4,s11,USER_EVT_WRITE,0)
  828. FSM_RULE_ENTRY(s4, s14, USER_EVT_SAM_IC, 0)
  829. FSM_RULE_ENTRY(s4, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  830. FSM_RULE_ENTRY(s4, s2, USER_EVT_ISSUE_EX_FINISHED, 2)
  831. FSM_RULE_ENTRY(s4, s6, USER_EVT_ISSUE_EX_FINISHED, 6)
  832. FSM_RULE_ENTRY(s4, s5, USER_EVT_PREONLINE, 0)
  833. FSM_RULE_ENTRY(s4, s5, USER_EVT_POSTONLINE, 0)
  834. FSM_RULE_ENTRY(s5,s4,USER_EVT_READ_FINISHED,0)
  835. FSM_RULE_ENTRY(s5,s9,USER_EVT_READ_FINISHED,1)
  836. FSM_RULE_ENTRY(s5,s4,USER_EVT_READ_FINISHED,2)
  837. FSM_RULE_ENTRY(s5, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  838. FSM_RULE_ENTRY(s5, s4, USER_EVT_EXIT, 0)
  839. FSM_RULE_ENTRY(s5, s4, USER_EVT_PREONLINEFINISHED, 0)
  840. FSM_RULE_ENTRY(s5, s4, USER_EVT_POSTONLINEFINISHED, 0)
  841. FSM_RULE_ENTRY(s6,s7,USER_EVT_EJECTFINISHED,0)
  842. FSM_RULE_ENTRY(s6,s9,USER_EVT_EJECTFINISHED,1)
  843. FSM_RULE_ENTRY(s6, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  844. FSM_RULE_ENTRY(s7,s2,USER_EVT_WAITFINISHED,0)
  845. FSM_RULE_ENTRY(s7,s9,USER_EVT_WAITFINISHED,1)
  846. FSM_RULE_ENTRY(s7,s8,USER_EVT_WAITFINISHED,2)
  847. FSM_RULE_ENTRY(s7, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  848. FSM_RULE_ENTRY(s8,s2,USER_EVT_CAPTUREFINISHED,0)
  849. FSM_RULE_ENTRY(s8,s9,USER_EVT_CAPTUREFINISHED,1)
  850. FSM_RULE_ENTRY(s8, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  851. FSM_RULE_ENTRY(s9, s2, USER_EVT_RESETFINISHED, 0)
  852. FSM_RULE_ENTRY(s9, s0, USER_EVT_RESETFINISHED, 2)
  853. FSM_RULE_ENTRY(s9, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  854. FSM_RULE_ENTRY(s10,s4,USER_EVT_ISSUE_FINISHED,0)
  855. FSM_RULE_ENTRY(s10,s9,USER_EVT_ISSUE_FINISHED,1)
  856. FSM_RULE_ENTRY(s10,s2,USER_EVT_ISSUE_FINISHED,2)
  857. FSM_RULE_ENTRY(s10, s6, USER_EVT_ISSUE_EX_FINISHED, 6)
  858. FSM_RULE_ENTRY(s10, s4, USER_EVT_ISSUE_EX_FINISHED, 0)
  859. FSM_RULE_ENTRY(s10, s9, USER_EVT_ISSUE_EX_FINISHED, 1)
  860. FSM_RULE_ENTRY(s10, s2, USER_EVT_ISSUE_EX_FINISHED, 2)
  861. FSM_RULE_ENTRY(s10, s6, USER_EVT_ISSUE_EX_FINISHED, 6)
  862. FSM_RULE_ENTRY(s10, s2, USER_EVT_ISSUE_EX_FINISHED, 8)
  863. FSM_RULE_ENTRY(s10, s2, USER_EVT_EXIT, 0)
  864. FSM_RULE_ENTRY(s11,s4,USER_EVT_WRITE_FINISHED,0)
  865. FSM_RULE_ENTRY(s11,s4,USER_EVT_WRITE_FINISHED,1)
  866. FSM_RULE_ENTRY(s14, s4, USER_EVT_SAM_IC_FINISHED, 0)
  867. END_FSM_RULE()
  868. CCardIssuerFSM() : m_bCancelAccept(false),m_bWaitingAccept(false),
  869. m_bWaitAccepteMore(false),m_bExit(false),m_resetTimes(0),m_testResult(Error_Succeed)
  870. //,m_pTACReject(NULL),m_pIACOnline(NULL),m_pTACOnline(NULL),m_pIACDefault(NULL),m_pTACDefault(NULL)
  871. ,m_bCDA(false),m_pDataToARQC(NULL),m_bIssuingExit(false)
  872. ,m_bCardIssued(false),m_issueStatusFromFile(1),m_issueStatus(1),m_currCardNo("")
  873. , m_captureReason(""), m_machineType(1), m_currentHopper(1), m_hopperNum(1)
  874. , m_bSettingMaterial(false) , m_addCardNo(""), m_addCardSerial(""), m_hasCardWhileDevOpen(false)
  875. , m_bCancelByRFIC(false), m_devOpenFailedCount(0)
  876. , m_EacQueryHost(""),m_eacQueryFlag(0), m_bUseCardnoMismatch(false), m_ICRetryTimes(1)
  877. , m_bCardFromHopper(true), m_bStopUseRF(false),m_rfVendorList(""), m_bUseRFTillNext(false), m_csSwallowCardUrl(""), m_csSyncMaterialUrl("")
  878. {
  879. HARDWARE_ENTITY_RESET_ENTITYID(m_entCode, 0x203);
  880. cmdDecodeMag2 = NULL;
  881. cmdDecodeEx = NULL;
  882. m_aidList.Init(3);
  883. m_aidList[0] = "A000000333";
  884. m_aidList[1] = "A0000000108888";
  885. m_aidList[2] = "A000000790";
  886. }
  887. ~CCardIssuerFSM(){}
  888. virtual ErrorCodeEnum OnInit();
  889. virtual ErrorCodeEnum OnExit();
  890. void s0_on_entry();
  891. void s0_on_exit();
  892. unsigned int s0_on_event(FSMEvent* event);
  893. void s1_on_entry();
  894. void s1_on_exit();
  895. unsigned int s1_on_event(FSMEvent* event);
  896. void s2_on_entry();
  897. void s2_on_exit();
  898. unsigned int s2_on_event(FSMEvent* event);
  899. void s3_on_entry();
  900. void s3_on_exit();
  901. unsigned int s3_on_event(FSMEvent* event);
  902. void s4_on_entry();
  903. void s4_on_exit();
  904. unsigned int s4_on_event(FSMEvent* event);
  905. void s5_on_entry();
  906. void s5_on_exit();
  907. unsigned int s5_on_event(FSMEvent* event);
  908. void s6_on_entry();
  909. void s6_on_exit();
  910. unsigned int s6_on_event(FSMEvent* event);
  911. void s7_on_entry();
  912. void s7_on_exit();
  913. unsigned int s7_on_event(FSMEvent* event);
  914. void s8_on_entry();
  915. void s8_on_exit();
  916. unsigned int s8_on_event(FSMEvent* event);
  917. void s9_on_entry();
  918. void s9_on_exit();
  919. unsigned int s9_on_event(FSMEvent* event);
  920. void s10_on_entry();
  921. void s10_on_exit();
  922. unsigned int s10_on_event(FSMEvent* event);
  923. void s11_on_entry();
  924. void s11_on_exit();
  925. unsigned int s11_on_event(FSMEvent* event);
  926. void s14_on_entry();
  927. void s14_on_exit();
  928. unsigned int s14_on_event(FSMEvent* event);
  929. ErrorCodeEnum OpenDevice(BYTE btOpenType, const char *pDevSN);
  930. int Initial();
  931. bool GetDevStatus(bool bPrint=true);
  932. int UnAcceptCard();
  933. int CaptureCard(SpReqAnsContext<CardIssuerStandService_Capture_Req,CardIssuerStandService_Capture_Ans>::Pointer ctx);
  934. int EjectCard(SpReqAnsContext<CardIssuerStandService_Eject_Req,CardIssuerStandService_Eject_Ans>::Pointer ctx);
  935. int WaitFetchingCard();
  936. int ReadCard(SpReqAnsContext<CardIssuerStandService_Read_Req, CardIssuerStandService_Read_Ans>::Pointer ctx);
  937. int PreOnline(SpReqAnsContext<CardIssuerStandService_PreOnline_Req, CardIssuerStandService_PreOnline_Ans>::Pointer ctx);
  938. int PostOnline(SpReqAnsContext<CardIssuerStandService_PostOnline_Req, CardIssuerStandService_PostOnline_Ans>::Pointer ctx);
  939. int ReadCard_Contact(SpReqAnsContext<CardIssuerStandService_Read_Req,CardIssuerStandService_Read_Ans>::Pointer ctx, bool& bICOK);
  940. int PreOnline_Contact(SpReqAnsContext<CardIssuerStandService_PreOnline_Req,CardIssuerStandService_PreOnline_Ans>::Pointer ctx, bool& bICOK);
  941. int PostOnline_Contact(SpReqAnsContext<CardIssuerStandService_PostOnline_Req,CardIssuerStandService_PostOnline_Ans>::Pointer ctx, bool& bICOK);
  942. int ReadCard_RF(SpReqAnsContext<CardIssuerStandService_Read_Req, CardIssuerStandService_Read_Ans>::Pointer ctx);
  943. int PreOnline_RF(SpReqAnsContext<CardIssuerStandService_PreOnline_Req, CardIssuerStandService_PreOnline_Ans>::Pointer ctx);
  944. int PostOnline_RF(SpReqAnsContext<CardIssuerStandService_PostOnline_Req, CardIssuerStandService_PostOnline_Ans>::Pointer ctx);
  945. int Reset();
  946. int InternalAcceptCard();
  947. int AcceptCard(SpReqAnsContext<CardIssuerStandService_Insert_Req, CardIssuerStandService_Insert_Ans>::Pointer ctx);
  948. int IssueCard(SpReqAnsContext<CardIssuerStandService_Issue_Req, CardIssuerStandService_Issue_Ans>::Pointer ctx, SpReqAnsContext<CardIssuerStandService_IssueEx_Req, CardIssuerStandService_IssueEx_Ans>::Pointer ctxEx);
  949. int WriteCard(SpReqAnsContext<CardIssuerStandService_WriteTrack_Req,CardIssuerStandService_WriteTrack_Ans>::Pointer ctx);
  950. bool GetWaitFlag(){return m_bWaitingAccept;}
  951. void SetWaitMore(){m_bWaitAccepteMore = true;}
  952. void SetExitFlag(bool bFlag=true){m_bExit = bFlag;}
  953. bool FSMSetIssueFlag(int value=1);
  954. void FrontSetIssueFlag(bool bValue = true){ FSMSetIssueFlag(bValue); }
  955. int QueryIssueFlag(){ return m_issueStatus; }
  956. bool SetCardCaptured(const int num,bool bNewClear=false);
  957. bool SetCardIssued(const int num,const int hopper);
  958. bool SetCardRemains(const int num, const int hopper,bool bInit = false);
  959. bool SetCardMixed(const int num, const int hopper);
  960. ErrorCodeEnum MachineMoveCardBackNotHold();
  961. ErrorCodeEnum MachineMoveCardFrontGate(bool bInBussiness=false);
  962. void SelfTest(EntityTestEnum eTestType,CSmartPointer<ITransactionContext> pTransactionContext);
  963. DevStateEnum GetDevState() const
  964. {
  965. if ((m_eDevState == DEVICE_STATUS_NORMAL)
  966. && ((m_bHasHopper[0] && m_mixedEx[0] >= 3) || !m_bHasHopper[0])
  967. && ((m_bHasHopper[1] && m_mixedEx[1] >= 3) || !m_bHasHopper[1])
  968. && ((m_bHasHopper[2] && m_mixedEx[2] >= 3) || !m_bHasHopper[2]))
  969. return DEVICE_STATUS_MAINTAINCE;
  970. else
  971. return m_eDevState;
  972. }
  973. int QueryCardInfo();
  974. int UpdateLocalRunCfg(CAutoArray<int> hopperArr);
  975. int SyncDataToDB(bool bMaintain[12],bool bSetCaptured=true);//同步物料计数
  976. void SetHopperNum(int hopperNum);
  977. void DoExitWhenIdle();
  978. int SAMICCommand(SpReqAnsContext<CardIssuerStandService_SAMICCommand_Req, CardIssuerStandService_SAMICCommand_Ans>::Pointer ctx);
  979. bool WriteCardInfo(CSmartPointer<IConfigInfo> &cfgRun, const char *acc, const char* serial, int slot, bool bClear = false, bool bHasCard = false);
  980. bool ReadCardInfo(CSmartPointer<IConfigInfo> &cfgRun, CSimpleStringA &acc, CSimpleStringA &serial, int slot);
  981. void DecodeTracksData(const char *track2, DWORD dwT2size, const char *track3, DWORD dwT3size,char *&magData,bool bT2OK=true,bool bT3OK=true);
  982. int GetFSMState()
  983. {
  984. //DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)(CSimpleStringA::Format("m_currentFSMState:%d", m_currentFSMState));
  985. return m_currentFSMState;
  986. }
  987. void GetCardInfo(int &findCard, int &cardPos)
  988. {
  989. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)(CSimpleStringA::Format("<GetCardInfo>, findCard:%d, cardPos:%d", findCard, cardPos));
  990. findCard = m_findCard;
  991. cardPos = m_cardPos;
  992. }
  993. int SplitDevModelInfo();
  994. void SetCancelByRFICFlag(bool bCancel = true) { m_bCancelByRFIC = bCancel; }
  995. CSimpleStringA GetPreOnlineICCardNo() { return m_currCardNo; }
  996. void CloseAndClearDevObj(bool bCheckConnecting = true, bool bCloseOnly = false);
  997. void SetEnterMainPage();
  998. static void HttpsLogCallBack(const char* logtxt);
  999. //0:unknow(havn't access microservice or access failed),1:both mag & ic ,2:mag only,3:ic only
  1000. int JudgeCardType(CSimpleStringA cardno, bool &bMismatch);
  1001. void QueryCIStatus(SpReqAnsContext<CardIssuerStandService_QueryCIStatus_Req, CardIssuerStandService_QueryCIStatus_Ans>::Pointer ctx);
  1002. bool RegistCardWhileCaptureCard(CSimpleStringA cardno);
  1003. bool SyncMaterialCount(IHttpFunc* client,SyncMaterialCountInfo syncInfo);
  1004. protected:
  1005. int m_iInsertTries;
  1006. int m_resetTries;
  1007. int m_ejectTries;
  1008. private:
  1009. ///
  1010. int m_resetTimes;
  1011. lpCMBdecodeMag2 cmdDecodeMag2;
  1012. lpCMBdecodeEx cmdDecodeEx;
  1013. bool m_bCancelAccept, m_bWaitingAccept, m_bWaitAccepteMore, m_bExit
  1014. , m_bCDA, m_bIssuingExit, m_bCardIssued, m_bHasHopper[HOPPER_NUM]
  1015. , m_bSettingMaterial, m_hasCardWhileDevOpen, m_bCancelByRFIC
  1016. , m_bCardActiveNotify, m_bCardFromHopper, m_bUseCardnoMismatch, m_bStopUseRF;
  1017. bool m_bUseRFTillNext;//if ReadCard by RF,the following PreOnline & PostOnline always use RF till the next card(insert/issue)
  1018. ErrorCodeEnum m_testResult;
  1019. int m_CardCaptured;
  1020. int m_issueStatusFromFile, m_issueStatus/*the status maybe changed by Business call*/;
  1021. //1:default, 2:SCI, 3:no cfg
  1022. int m_machineType;
  1023. WORD m_majorVerion, m_minorVerion;
  1024. int m_currentHopper,m_devOpenFailedCount;
  1025. int m_maxSlot,m_findCard,m_cardPos,m_currentFSMState,m_maxRetainCount, m_eacQueryFlag/*accout query*/
  1026. ,m_ICRetryTimes;
  1027. CSimpleStringA m_CardBoxNoEx[HOPPER_NUM], m_PsbCodeEx[HOPPER_NUM], m_PsbNameEx[HOPPER_NUM], m_MaintainerEx[HOPPER_NUM],m_csMaintainTimeEx[HOPPER_NUM];
  1028. int m_CardInitEx[HOPPER_NUM], m_CardPercentEx[HOPPER_NUM], m_remainsEx[HOPPER_NUM], m_issuedEx[HOPPER_NUM], m_mixedEx[HOPPER_NUM],m_hopperNum;
  1029. DWORD m_MaintainTimeEx[HOPPER_NUM];
  1030. BYTE m_connectType, m_r1[128], m_r2[128], m_r3[128], m_priKey[ONE_K / 2], m_devPubKey[ONE_K / 2];
  1031. CardIssuerStatus m_devStatus;
  1032. CCardProcess *m_pCardProcess;
  1033. CAutoArray<CSimpleStringA> m_aidList;
  1034. char *m_pDataToARQC;
  1035. long xxTest;
  1036. CSimpleStringA m_currCardNo, m_captureReason, m_csMachineType, m_terminalNo, m_addCardNo, m_addCardSerial, m_rfVendorList, m_csRF;
  1037. char m_AuthCode[2];
  1038. vector<CMBBin> m_vBin;
  1039. int SplitTrack2(CSimpleStringA pTrack2,Track2Data &decodeData);
  1040. bool JustReadCardNo();
  1041. bool IsValidCardNo(const char*,int);
  1042. void GetVendorDllName(CSimpleStringA &dllName);
  1043. bool AccountExchange(const char *origAcc, CSimpleStringA &acc,int dir=1);
  1044. bool LoadCMBPrint(CSimpleStringA csBinPath);
  1045. DevCategoryInfo m_devCat;
  1046. bool ToRegistCaptureCardInfo();
  1047. bool IfUseRf();
  1048. CSimpleStringA m_EacQueryHost, m_csSwallowCardUrl, m_csSyncMaterialUrl;
  1049. MagTracks m_magTracks;
  1050. public:
  1051. int EjectJS(SpReqAnsContext<CardIssuerStandService_EjectJS_Req, CardIssuerStandService_EjectJS_Ans>::Pointer ctx);
  1052. int CaptureJS(SpReqAnsContext<CardIssuerStandService_CaptureJS_Req, CardIssuerStandService_CaptureJS_Ans>::Pointer ctx);
  1053. void QueryHasCardJS(SpReqAnsContext<CardIssuerStandService_QueryHasCardJS_Req, CardIssuerStandService_QueryHasCardJS_Ans>::Pointer ctx);
  1054. int PostOnlineJS(SpReqAnsContext<CardIssuerStandService_PostOnlineJS_Req, CardIssuerStandService_PostOnlineJS_Ans>::Pointer ctx);
  1055. int IssueFromBoxJS(SpReqAnsContext<CardIssuerStandService_IssueFromBoxJS_Req, CardIssuerStandService_IssueFromBoxJS_Ans>::Pointer ctx);
  1056. int ReadJS(SpReqAnsContext<CardIssuerStandService_ReadJS_Req, CardIssuerStandService_ReadJS_Ans>::Pointer ctx);
  1057. int InsertJS(SpReqAnsContext<CardIssuerStandService_InsertJS_Req, CardIssuerStandService_InsertJS_Ans>::Pointer ctx);
  1058. int ExitToMainPage();
  1059. int PostOnlineJS_Contact(SpReqAnsContext<CardIssuerStandService_PostOnlineJS_Req, CardIssuerStandService_PostOnlineJS_Ans>::Pointer ctx, bool& bICOK);
  1060. int PostOnlineJS_RF(SpReqAnsContext<CardIssuerStandService_PostOnlineJS_Req, CardIssuerStandService_PostOnlineJS_Ans>::Pointer ctx);
  1061. int ReadMag(SpReqAnsContext<CardIssuerStandService_ReadJS_Req, CardIssuerStandService_ReadJS_Ans>::Pointer ctx, bool& bReadCardInfo, bool& bReadMag, CSimpleStringA& t2Account);
  1062. int CheckCardType(CSimpleStringA cardNo, bool bReadMag, int& ICtype);
  1063. int PreOnlineJS_Contact(SpReqAnsContext<CardIssuerStandService_ReadJS_Req, CardIssuerStandService_ReadJS_Ans>::Pointer ctx, bool& bICOK, bool& bContinue);
  1064. int PreOnlineJS_RF(SpReqAnsContext<CardIssuerStandService_ReadJS_Req, CardIssuerStandService_ReadJS_Ans>::Pointer ctx);
  1065. DWORD GetFsmStateErrCode();
  1066. CSimpleStringA MaskCardno(const char* cardno);
  1067. void GetCardProcessLastErr(ErrorCodeEnum& eErrCode, CSimpleStringA& lastApiName, CSimpleStringA& alarmMsg, CSimpleStringA& csErrMsgWithReturnCode);
  1068. };
  1069. struct InitTask : public ITaskSp
  1070. {
  1071. CCardIssuerFSM* fsm;
  1072. InitTask(CCardIssuerFSM* f) : fsm(f) {}
  1073. void Process()
  1074. {
  1075. FSMEvent *e = new FSMEvent(USER_EVT_INITFINISHED);
  1076. e->param1 = fsm->Initial();
  1077. fsm->PostEventFIFO(e);
  1078. }
  1079. };
  1080. struct AcceptTask : public ITaskSp
  1081. {
  1082. CCardIssuerFSM* fsm;
  1083. SpReqAnsContext<CardIssuerStandService_Insert_Req, CardIssuerStandService_Insert_Ans>::Pointer ctx;
  1084. AcceptTask(CCardIssuerFSM* f) : fsm(f) {}
  1085. void Process()
  1086. {
  1087. LOG_FUNCTION();
  1088. FSMEvent *e = new FSMEvent(USER_EVT_ACCEPTFINISHED);
  1089. e->param1 = fsm->AcceptCard(ctx);
  1090. fsm->PostEventFIFO(e);
  1091. }
  1092. };
  1093. struct IssueTask : public ITaskSp
  1094. {
  1095. CCardIssuerFSM* fsm;
  1096. SpReqAnsContext<CardIssuerStandService_Issue_Req, CardIssuerStandService_Issue_Ans>::Pointer ctx;
  1097. SpReqAnsContext<CardIssuerStandService_IssueEx_Req, CardIssuerStandService_IssueEx_Ans>::Pointer ctxEx;
  1098. IssueTask(CCardIssuerFSM* f) : fsm(f) {}
  1099. void Process()
  1100. {
  1101. LOG_FUNCTION();
  1102. FSMEvent *e;
  1103. if (ctx != NULL)
  1104. e = new FSMEvent(USER_EVT_ISSUE_FINISHED);
  1105. else if (ctxEx != NULL)
  1106. e = new FSMEvent(USER_EVT_ISSUE_EX_FINISHED);
  1107. else
  1108. {
  1109. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("IssueTask:ctx is null");
  1110. return;
  1111. }
  1112. e->param1 = fsm->IssueCard(ctx,ctxEx);
  1113. fsm->PostEventFIFO(e);
  1114. }
  1115. };
  1116. struct ReadTask : public ITaskSp
  1117. {
  1118. SpReqAnsContext<CardIssuerStandService_Read_Req,CardIssuerStandService_Read_Ans>::Pointer ctx;
  1119. CCardIssuerFSM* fsm;
  1120. ReadTask(CCardIssuerFSM* f) : fsm(f) {}
  1121. void Process()
  1122. {
  1123. CardReadFinishedEvent *e = new CardReadFinishedEvent();
  1124. e->ctx = ctx;
  1125. e->param1 = fsm->ReadCard(ctx);
  1126. fsm->PostEventFIFO(e);
  1127. }
  1128. };
  1129. struct PreOnlineTask : public ITaskSp
  1130. {
  1131. SpReqAnsContext<CardIssuerStandService_PreOnline_Req,CardIssuerStandService_PreOnline_Ans>::Pointer ctx;
  1132. CCardIssuerFSM* fsm;
  1133. PreOnlineTask(CCardIssuerFSM* f) : fsm(f) {}
  1134. void Process()
  1135. {
  1136. FSMEvent *e = new FSMEvent(USER_EVT_PREONLINEFINISHED);
  1137. e->param1 = fsm->PreOnline(ctx);//oilyang@20220611 实际上,为简化处理,PreOnline函数默认返回0
  1138. fsm->PostEventFIFO(e);
  1139. }
  1140. };
  1141. struct PostOnlineTask : public ITaskSp
  1142. {
  1143. SpReqAnsContext<CardIssuerStandService_PostOnline_Req,CardIssuerStandService_PostOnline_Ans>::Pointer ctx;
  1144. CCardIssuerFSM* fsm;
  1145. PostOnlineTask(CCardIssuerFSM* f) : fsm(f) {}
  1146. void Process()
  1147. {
  1148. FSMEvent *e = new FSMEvent(USER_EVT_POSTONLINEFINISHED);
  1149. e->param1 = fsm->PostOnline(ctx);
  1150. fsm->PostEventFIFO(e);
  1151. }
  1152. };
  1153. struct CaptureTask : public ITaskSp
  1154. {
  1155. CCardIssuerFSM* fsm;
  1156. SpReqAnsContext<CardIssuerStandService_Capture_Req,CardIssuerStandService_Capture_Ans>::Pointer ctx;
  1157. CaptureTask(CCardIssuerFSM* f) : fsm(f) {}
  1158. void Process()
  1159. {
  1160. FSMEvent *e = new FSMEvent(USER_EVT_CAPTUREFINISHED);
  1161. e->param1 = fsm->CaptureCard(ctx);
  1162. fsm->PostEventFIFO(e);
  1163. }
  1164. };
  1165. struct EjectTask : public ITaskSp
  1166. {
  1167. SpReqAnsContext<CardIssuerStandService_Eject_Req,CardIssuerStandService_Eject_Ans>::Pointer ctx;
  1168. CCardIssuerFSM* fsm;
  1169. EjectTask(CCardIssuerFSM* f) : fsm(f) {}
  1170. void Process()
  1171. {
  1172. FSMEvent *e = new FSMEvent(USER_EVT_EJECTFINISHED);
  1173. e->param1 = fsm->EjectCard(ctx);
  1174. fsm->PostEventFIFO(e);
  1175. }
  1176. };
  1177. struct WaitFetchingTask : public ITaskSp
  1178. {
  1179. CCardIssuerFSM* fsm;
  1180. WaitFetchingTask(CCardIssuerFSM* f) : fsm(f) {}
  1181. void Process()
  1182. {
  1183. FSMEvent *e = new FSMEvent(USER_EVT_WAITFINISHED);
  1184. e->param1 = fsm->WaitFetchingCard();
  1185. fsm->PostEventFIFO(e);
  1186. }
  1187. };
  1188. struct ResetTask : public ITaskSp
  1189. {
  1190. CCardIssuerFSM* fsm;
  1191. ResetTask(CCardIssuerFSM* f) : fsm(f) {}
  1192. void Process()
  1193. {
  1194. ResetFinishedEvent *e = new ResetFinishedEvent();
  1195. e->param1 = fsm->Reset();
  1196. fsm->PostEventFIFO(e);
  1197. }
  1198. };
  1199. struct WriteTask : public ITaskSp
  1200. {
  1201. SpReqAnsContext<CardIssuerStandService_WriteTrack_Req,CardIssuerStandService_WriteTrack_Ans>::Pointer ctx;
  1202. CCardIssuerFSM* fsm;
  1203. WriteTask(CCardIssuerFSM* f) : fsm(f) {}
  1204. void Process()
  1205. {
  1206. CardWriteFinishedEvent *e = new CardWriteFinishedEvent();
  1207. e->ctx = ctx;
  1208. e->param1 = fsm->WriteCard(ctx);
  1209. fsm->PostEventFIFO(e);
  1210. }
  1211. };
  1212. struct DoExitWhenIdleTask : public ITaskSp
  1213. {
  1214. CCardIssuerFSM* fsm;
  1215. DoExitWhenIdleTask(CCardIssuerFSM* f) : fsm(f) {}
  1216. void Process()
  1217. {
  1218. fsm->DoExitWhenIdle();
  1219. }
  1220. };
  1221. struct SAMICCommandTask : public ITaskSp
  1222. {
  1223. CCardIssuerFSM* fsm;
  1224. SpReqAnsContext<CardIssuerStandService_SAMICCommand_Req, CardIssuerStandService_SAMICCommand_Ans>::Pointer ctx;
  1225. SAMICCommandTask(CCardIssuerFSM* f) : fsm(f) {}
  1226. void Process()
  1227. {
  1228. FSMEvent* e = new FSMEvent(USER_EVT_SAM_IC_FINISHED);
  1229. e->param1 = fsm->SAMICCommand(ctx);
  1230. fsm->PostEventFIFO(e);
  1231. }
  1232. };
  1233. struct RegistCaptureCardInfoTask : public ITaskSp
  1234. {
  1235. CCardIssuerFSM* fsm;
  1236. CSimpleStringA cardno;
  1237. RegistCaptureCardInfoTask(CCardIssuerFSM* f, CSimpleStringA cardno) : fsm(f),cardno(cardno) {}
  1238. void Process()
  1239. {
  1240. fsm->RegistCardWhileCaptureCard(cardno);
  1241. }
  1242. };
  1243. struct SyncMaterialCountTask : public ITaskSp
  1244. {
  1245. CCardIssuerFSM* fsm;
  1246. SyncMaterialCountInfo syncInfo;
  1247. SyncMaterialCountTask(CCardIssuerFSM* f, SyncMaterialCountInfo syncMaterialInfo){
  1248. fsm = f;
  1249. syncInfo = syncMaterialInfo;
  1250. }
  1251. void Process()
  1252. {
  1253. LOG_FUNCTION();
  1254. //同步物料信息
  1255. IHttpFunc* client;
  1256. client = create_http(fsm->HttpsLogCallBack);
  1257. bool ret = fsm->SyncMaterialCount(client,syncInfo);
  1258. client->Destory();
  1259. }
  1260. };
  1261. #pragma region JS接口 工作线程
  1262. //吐卡
  1263. struct EjectJSTask : public ITaskSp
  1264. {
  1265. CCardIssuerFSM* fsm;
  1266. SpReqAnsContext<CardIssuerStandService_EjectJS_Req, CardIssuerStandService_EjectJS_Ans>::Pointer ctx;
  1267. EjectJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1268. void Process()
  1269. {
  1270. FSMEvent* e = new FSMEvent(USER_EVT_JS_EJECT_FINISHED);
  1271. //e->param1 = fsm->EjectJS(ctx);
  1272. fsm->PostEventFIFO(e);
  1273. }
  1274. };
  1275. //吞卡
  1276. struct CaptureJSTask : public ITaskSp
  1277. {
  1278. CCardIssuerFSM* fsm;
  1279. SpReqAnsContext<CardIssuerStandService_CaptureJS_Req, CardIssuerStandService_CaptureJS_Ans>::Pointer ctx;
  1280. CaptureJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1281. void Process()
  1282. {
  1283. FSMEvent* e = new FSMEvent(USER_EVT_JS_CAPTURE_FINISHED);
  1284. //e->param1 = fsm->CaptureJS(ctx);
  1285. fsm->PostEventFIFO(e);
  1286. }
  1287. };
  1288. //联机后处理
  1289. struct PostOnlineJSTask : public ITaskSp
  1290. {
  1291. CCardIssuerFSM* fsm;
  1292. SpReqAnsContext<CardIssuerStandService_PostOnlineJS_Req, CardIssuerStandService_PostOnlineJS_Ans>::Pointer ctx;
  1293. PostOnlineJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1294. void Process()
  1295. {
  1296. FSMEvent* e = new FSMEvent(USER_EVT_JS_POSTONLINE_FINISHED);
  1297. //e->param1 = fsm->PostOnlineJS(ctx);
  1298. fsm->PostEventFIFO(e);
  1299. }
  1300. };
  1301. //卡箱发卡
  1302. struct IssueFromBoxJSTask : public ITaskSp
  1303. {
  1304. CCardIssuerFSM* fsm;
  1305. SpReqAnsContext<CardIssuerStandService_IssueFromBoxJS_Req, CardIssuerStandService_IssueFromBoxJS_Ans>::Pointer ctx;
  1306. IssueFromBoxJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1307. void Process()
  1308. {
  1309. FSMEvent* e = new FSMEvent(USER_EVT_JS_ISSUE_FROM_BOX_FINISHED);
  1310. //e->param1 = fsm->IssueFromBoxJS(ctx);
  1311. fsm->PostEventFIFO(e);
  1312. }
  1313. };
  1314. //读卡
  1315. struct ReadJSTask : public ITaskSp
  1316. {
  1317. CCardIssuerFSM* fsm;
  1318. SpReqAnsContext<CardIssuerStandService_ReadJS_Req, CardIssuerStandService_ReadJS_Ans>::Pointer ctx;
  1319. ReadJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1320. void Process()
  1321. {
  1322. FSMEvent* e = new FSMEvent(USER_EVT_JS_READ_FINISHED);
  1323. //e->param1 = fsm->ReadJS(ctx);
  1324. fsm->PostEventFIFO(e);
  1325. }
  1326. };
  1327. struct InsertJSTask : public ITaskSp
  1328. {
  1329. CCardIssuerFSM* fsm;
  1330. SpReqAnsContext<CardIssuerStandService_InsertJS_Req, CardIssuerStandService_InsertJS_Ans>::Pointer ctx;
  1331. InsertJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1332. void Process()
  1333. {
  1334. LOG_FUNCTION();
  1335. FSMEvent* e = new FSMEvent(USER_EVT_JS_INSERT_FINISHED);
  1336. //e->param1 = fsm->InsertJS(ctx);
  1337. fsm->PostEventFIFO(e);
  1338. }
  1339. };
  1340. //故障自检task
  1341. struct QuickSelfcheckTask : public ITaskSp
  1342. {
  1343. CCardIssuerFSM* fsm;
  1344. QuickSelfcheckTask(CCardIssuerFSM* f) : fsm(f) {}
  1345. void Process()
  1346. {
  1347. QuickSelfcheckFinishEvent* e = new QuickSelfcheckFinishEvent();
  1348. //Sleep(fsm->m_SelfcheckSleepTime);
  1349. //e->param1 = fsm->QuickSelfCheckImpl();
  1350. fsm->PostEventFIFO(e);
  1351. }
  1352. };
  1353. #pragma endregion JS接口 工作线程
  1354. #endif //__CARD_ISSUER_FSM_H