CardIssuerStandFSM.h 43 KB

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