CardIssuerFSM.h 45 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474
  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 "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_JS_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,s15,s16};
  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. FSM_STATE_ENTRY(s15, "ReadJSing", s15_on_entry, s15_on_exit, s15_on_event)
  803. FSM_STATE_ENTRY(s16, "IssueJSing", s16_on_entry, s16_on_exit, s16_on_event)
  804. END_FSM_STATE()
  805. BEGIN_FSM_RULE(CCardIssuerFSM,s0)
  806. FSM_RULE_ENTRY(s0, s2, USER_EVT_TEST, 0)
  807. FSM_RULE_ENTRY(s0,s1,USER_EVT_INIT,0)
  808. FSM_RULE_ENTRY(s0, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  809. FSM_RULE_ENTRY(s1,s2,USER_EVT_INITFINISHED,0)
  810. FSM_RULE_ENTRY(s1,s9,USER_EVT_INITFINISHED,1)
  811. FSM_RULE_ENTRY(s1, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  812. FSM_RULE_ENTRY(s2,s3,USER_EVT_ACCEPT,0)
  813. // FSM_RULE_ENTRY(s2,s9,USER_EVT_ACCEPT,1)
  814. FSM_RULE_ENTRY(s2, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  815. FSM_RULE_ENTRY(s2,s10,USER_EVT_ISSUE,0)
  816. FSM_RULE_ENTRY(s2, s10, USER_EVT_ISSUE_EX, 0)
  817. FSM_RULE_ENTRY(s2, s3, USER_EVT_JS_INSERT, 0)//JS 插卡
  818. FSM_RULE_ENTRY(s2, s16, USER_EVT_JS_ISSUE_FROM_BOX, 0)//JS 卡箱发卡
  819. FSM_RULE_ENTRY(s2, s8, USER_EVT_JS_CAPTURE, 0)//JS 吞卡
  820. FSM_RULE_ENTRY(s3,s4,USER_EVT_ACCEPTFINISHED,0)
  821. FSM_RULE_ENTRY(s3,s9,USER_EVT_ACCEPTFINISHED,1)
  822. FSM_RULE_ENTRY(s3,s2,USER_EVT_ACCEPTFINISHED,2)
  823. FSM_RULE_ENTRY(s3,s2,USER_EVT_ACCEPTFINISHED,3)
  824. FSM_RULE_ENTRY(s3,s7,USER_EVT_ACCEPTFINISHED,4)
  825. FSM_RULE_ENTRY(s3, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  826. FSM_RULE_ENTRY(s3, s4, USER_EVT_JS_INSERT_FINISHED, 0)//JS 插卡成功
  827. FSM_RULE_ENTRY(s3, s9, USER_EVT_JS_INSERT_FINISHED, 1)//JS 查询硬件报错
  828. FSM_RULE_ENTRY(s3, s2, USER_EVT_JS_INSERT_FINISHED, 2)//JS 超时
  829. FSM_RULE_ENTRY(s3, s2, USER_EVT_JS_INSERT_FINISHED, 3)//JS 取消
  830. FSM_RULE_ENTRY(s3, s6, USER_EVT_JS_INSERT_FINISHED, 4)//JS 取消时有卡,吐卡
  831. FSM_RULE_ENTRY(s3, s2, USER_EVT_JS_INSERT_FINISHED, 5)//JS 插卡前内部已有卡
  832. FSM_RULE_ENTRY(s4,s5,USER_EVT_READ,0)
  833. FSM_RULE_ENTRY(s4,s6,USER_EVT_EJECT,0)
  834. FSM_RULE_ENTRY(s4,s6,USER_EVT_EXIT,0)
  835. FSM_RULE_ENTRY(s4,s8,USER_EVT_ACCEPT,0)
  836. FSM_RULE_ENTRY(s4,s8,USER_EVT_EXIT,1)
  837. FSM_RULE_ENTRY(s4,s8,USER_EVT_CAPTURE,0)
  838. FSM_RULE_ENTRY(s4,s11,USER_EVT_WRITE,0)
  839. FSM_RULE_ENTRY(s4, s14, USER_EVT_SAM_IC, 0)
  840. FSM_RULE_ENTRY(s4, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  841. FSM_RULE_ENTRY(s4, s2, USER_EVT_ISSUE_EX_FINISHED, 2)
  842. FSM_RULE_ENTRY(s4, s6, USER_EVT_ISSUE_EX_FINISHED, 6)
  843. FSM_RULE_ENTRY(s4, s5, USER_EVT_PREONLINE, 0)
  844. FSM_RULE_ENTRY(s4, s5, USER_EVT_POSTONLINE, 0)
  845. FSM_RULE_ENTRY(s4, s15, USER_EVT_JS_READ, 0)//JS 读卡
  846. FSM_RULE_ENTRY(s4, s15, USER_EVT_JS_POSTONLINE, 0)//JS 联机后
  847. FSM_RULE_ENTRY(s4, s6, USER_EVT_JS_EJECT, 0)//JS 吐卡
  848. FSM_RULE_ENTRY(s4, s8, USER_EVT_JS_CAPTURE, 0)//JS 吞卡
  849. FSM_RULE_ENTRY(s4, s6, USER_EVT_JS_EXIT_MIAN_PAGE, 0)//JS 退回首页吐卡
  850. FSM_RULE_ENTRY(s4, s8, USER_EVT_JS_EXIT_MIAN_PAGE, 1)//JS 退回首页吞卡
  851. FSM_RULE_ENTRY(s5,s4,USER_EVT_READ_FINISHED,0)
  852. FSM_RULE_ENTRY(s5,s9,USER_EVT_READ_FINISHED,1)
  853. FSM_RULE_ENTRY(s5,s4,USER_EVT_READ_FINISHED,2)
  854. FSM_RULE_ENTRY(s5, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  855. FSM_RULE_ENTRY(s5, s4, USER_EVT_EXIT, 0)
  856. FSM_RULE_ENTRY(s5, s4, USER_EVT_PREONLINEFINISHED, 0)
  857. FSM_RULE_ENTRY(s5, s4, USER_EVT_POSTONLINEFINISHED, 0)
  858. FSM_RULE_ENTRY(s6,s7,USER_EVT_EJECTFINISHED,0)
  859. FSM_RULE_ENTRY(s6,s9,USER_EVT_EJECTFINISHED,1)
  860. FSM_RULE_ENTRY(s6, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  861. FSM_RULE_ENTRY(s6, s2, USER_EVT_JS_EJECT_FINISHED, 0)//JS 吐卡取卡成功,取卡超时吞卡成功
  862. FSM_RULE_ENTRY(s6, s9, USER_EVT_JS_EJECT_FINISHED, 1)//JS 吐卡失败,取卡超时吞卡失败
  863. FSM_RULE_ENTRY(s7,s2,USER_EVT_WAITFINISHED,0)
  864. FSM_RULE_ENTRY(s7,s9,USER_EVT_WAITFINISHED,1)
  865. FSM_RULE_ENTRY(s7,s8,USER_EVT_WAITFINISHED,2)
  866. FSM_RULE_ENTRY(s7, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  867. FSM_RULE_ENTRY(s8,s2,USER_EVT_CAPTUREFINISHED,0)
  868. FSM_RULE_ENTRY(s8,s9,USER_EVT_CAPTUREFINISHED,1)
  869. FSM_RULE_ENTRY(s8, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  870. FSM_RULE_ENTRY(s8, s2, USER_EVT_JS_CAPTURE_FINISHED, 0)//JS 吞卡成功
  871. FSM_RULE_ENTRY(s8, s9, USER_EVT_JS_CAPTURE_FINISHED, 1)//JS 吞卡失败
  872. FSM_RULE_ENTRY(s9, s2, USER_EVT_RESETFINISHED, 0)
  873. FSM_RULE_ENTRY(s9, s0, USER_EVT_RESETFINISHED, 2)
  874. FSM_RULE_ENTRY(s9, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  875. FSM_RULE_ENTRY(s10,s4,USER_EVT_ISSUE_FINISHED,0)
  876. FSM_RULE_ENTRY(s10,s9,USER_EVT_ISSUE_FINISHED,1)
  877. FSM_RULE_ENTRY(s10,s2,USER_EVT_ISSUE_FINISHED,2)
  878. FSM_RULE_ENTRY(s10, s6, USER_EVT_ISSUE_EX_FINISHED, 6)
  879. FSM_RULE_ENTRY(s10, s4, USER_EVT_ISSUE_EX_FINISHED, 0)
  880. FSM_RULE_ENTRY(s10, s9, USER_EVT_ISSUE_EX_FINISHED, 1)
  881. FSM_RULE_ENTRY(s10, s2, USER_EVT_ISSUE_EX_FINISHED, 2)
  882. FSM_RULE_ENTRY(s10, s6, USER_EVT_ISSUE_EX_FINISHED, 6)
  883. FSM_RULE_ENTRY(s10, s2, USER_EVT_ISSUE_EX_FINISHED, 8)
  884. FSM_RULE_ENTRY(s10, s2, USER_EVT_EXIT, 0)
  885. FSM_RULE_ENTRY(s11,s4,USER_EVT_WRITE_FINISHED,0)
  886. FSM_RULE_ENTRY(s11,s4,USER_EVT_WRITE_FINISHED,1)
  887. FSM_RULE_ENTRY(s14, s4, USER_EVT_SAM_IC_FINISHED, 0)
  888. FSM_RULE_ENTRY(s15, s4, USER_EVT_JS_READ_FINISHED, 0)//JS 读卡结果返回
  889. FSM_RULE_ENTRY(s15, s2, USER_EVT_JS_READ_FINISHED, 1)//JS 无卡
  890. FSM_RULE_ENTRY(s15, s4, USER_EVT_JS_POSTONLINE_FINISHED, 0)//JS
  891. FSM_RULE_ENTRY(s15, s4, USER_EVT_JS_EXIT_MIAN_PAGE, 0)//退出事件
  892. FSM_RULE_ENTRY(s16, s4, USER_EVT_JS_ISSUE_FROM_BOX_FINISHED, 0)//JS 发卡成功
  893. FSM_RULE_ENTRY(s16, s2, USER_EVT_JS_ISSUE_FROM_BOX_FINISHED, 1)//JS 发卡失败
  894. FSM_RULE_ENTRY(s16, s9, USER_EVT_JS_ISSUE_FROM_BOX_FINISHED, 2)//JS 发卡故障
  895. FSM_RULE_ENTRY(s16, s8, USER_EVT_JS_ISSUE_FROM_BOX_FINISHED, 3)//JS 退回首页进行吞卡
  896. END_FSM_RULE()
  897. CCardIssuerFSM() : m_bCancelAccept(false),m_bWaitingAccept(false),
  898. m_bWaitAccepteMore(false),m_bExit(false),m_resetTimes(0),m_testResult(Error_Succeed)
  899. //,m_pTACReject(NULL),m_pIACOnline(NULL),m_pTACOnline(NULL),m_pIACDefault(NULL),m_pTACDefault(NULL)
  900. ,m_bCDA(false),m_pDataToARQC(NULL),m_bIssuingExit(false)
  901. ,m_bCardIssued(false),m_issueStatusFromFile(1),m_issueStatus(1),m_currCardNo("")
  902. , m_captureReason(""), m_machineType(1), m_currentHopper(1), m_hopperNum(1)
  903. , m_bSettingMaterial(false) , m_addCardNo(""), m_addCardSerial(""), m_hasCardWhileDevOpen(false)
  904. , m_bCancelByRFIC(false), m_devOpenFailedCount(0)
  905. , m_EacQueryHost(""),m_eacQueryFlag(0), m_bUseCardnoMismatch(false), m_ICRetryTimes(1)
  906. , m_bCardFromHopper(true), m_bStopUseRF(false),m_rfVendorList(""), m_bUseRFTillNext(false), m_csSwallowCardUrl(""), m_csSyncMaterialUrl("")
  907. , m_quickSelfcheck(false), m_SelfcheckSleepTime(10000), m_bCancelInsert(false), m_bReturnMainPage(false)
  908. {
  909. HARDWARE_ENTITY_RESET_ENTITYID(m_entCode, 0x203);
  910. cmdDecodeMag2 = NULL;
  911. cmdDecodeEx = NULL;
  912. m_aidList.Init(3);
  913. m_aidList[0] = "A000000333";
  914. m_aidList[1] = "A0000000108888";
  915. m_aidList[2] = "A000000790";
  916. }
  917. ~CCardIssuerFSM(){}
  918. virtual ErrorCodeEnum OnInit();
  919. virtual ErrorCodeEnum OnExit();
  920. void s0_on_entry();
  921. void s0_on_exit();
  922. unsigned int s0_on_event(FSMEvent* event);
  923. void s1_on_entry();
  924. void s1_on_exit();
  925. unsigned int s1_on_event(FSMEvent* event);
  926. void s2_on_entry();
  927. void s2_on_exit();
  928. unsigned int s2_on_event(FSMEvent* event);
  929. void s3_on_entry();
  930. void s3_on_exit();
  931. unsigned int s3_on_event(FSMEvent* event);
  932. void s4_on_entry();
  933. void s4_on_exit();
  934. unsigned int s4_on_event(FSMEvent* event);
  935. void s5_on_entry();
  936. void s5_on_exit();
  937. unsigned int s5_on_event(FSMEvent* event);
  938. void s6_on_entry();
  939. void s6_on_exit();
  940. unsigned int s6_on_event(FSMEvent* event);
  941. void s7_on_entry();
  942. void s7_on_exit();
  943. unsigned int s7_on_event(FSMEvent* event);
  944. void s8_on_entry();
  945. void s8_on_exit();
  946. unsigned int s8_on_event(FSMEvent* event);
  947. void s9_on_entry();
  948. void s9_on_exit();
  949. unsigned int s9_on_event(FSMEvent* event);
  950. void s10_on_entry();
  951. void s10_on_exit();
  952. unsigned int s10_on_event(FSMEvent* event);
  953. void s11_on_entry();
  954. void s11_on_exit();
  955. unsigned int s11_on_event(FSMEvent* event);
  956. void s14_on_entry();
  957. void s14_on_exit();
  958. unsigned int s14_on_event(FSMEvent* event);
  959. void s15_on_entry();
  960. void s15_on_exit();
  961. unsigned int s15_on_event(FSMEvent* event);
  962. void s16_on_entry();
  963. void s16_on_exit();
  964. unsigned int s16_on_event(FSMEvent* event);
  965. ErrorCodeEnum OpenDevice(BYTE btOpenType, const char *pDevSN);
  966. int Initial();
  967. bool GetDevStatus(bool bPrint=true);
  968. int UnAcceptCard();
  969. int CaptureCard(SpReqAnsContext<CardIssuerStandService_Capture_Req,CardIssuerStandService_Capture_Ans>::Pointer ctx);
  970. int EjectCard(SpReqAnsContext<CardIssuerStandService_Eject_Req,CardIssuerStandService_Eject_Ans>::Pointer ctx);
  971. int WaitFetchingCard();
  972. int ReadCard(SpReqAnsContext<CardIssuerStandService_Read_Req, CardIssuerStandService_Read_Ans>::Pointer ctx);
  973. int PreOnline(SpReqAnsContext<CardIssuerStandService_PreOnline_Req, CardIssuerStandService_PreOnline_Ans>::Pointer ctx);
  974. int PostOnline(SpReqAnsContext<CardIssuerStandService_PostOnline_Req, CardIssuerStandService_PostOnline_Ans>::Pointer ctx);
  975. int ReadCard_Contact(SpReqAnsContext<CardIssuerStandService_Read_Req,CardIssuerStandService_Read_Ans>::Pointer ctx, bool& bICOK);
  976. int PreOnline_Contact(SpReqAnsContext<CardIssuerStandService_PreOnline_Req,CardIssuerStandService_PreOnline_Ans>::Pointer ctx, bool& bICOK);
  977. int PostOnline_Contact(SpReqAnsContext<CardIssuerStandService_PostOnline_Req,CardIssuerStandService_PostOnline_Ans>::Pointer ctx, bool& bICOK);
  978. int ReadCard_RF(SpReqAnsContext<CardIssuerStandService_Read_Req, CardIssuerStandService_Read_Ans>::Pointer ctx);
  979. int PreOnline_RF(SpReqAnsContext<CardIssuerStandService_PreOnline_Req, CardIssuerStandService_PreOnline_Ans>::Pointer ctx);
  980. int PostOnline_RF(SpReqAnsContext<CardIssuerStandService_PostOnline_Req, CardIssuerStandService_PostOnline_Ans>::Pointer ctx);
  981. int Reset();
  982. int InternalAcceptCard();
  983. int AcceptCard(SpReqAnsContext<CardIssuerStandService_Insert_Req, CardIssuerStandService_Insert_Ans>::Pointer ctx);
  984. int IssueCard(SpReqAnsContext<CardIssuerStandService_Issue_Req, CardIssuerStandService_Issue_Ans>::Pointer ctx, SpReqAnsContext<CardIssuerStandService_IssueEx_Req, CardIssuerStandService_IssueEx_Ans>::Pointer ctxEx);
  985. int WriteCard(SpReqAnsContext<CardIssuerStandService_WriteTrack_Req,CardIssuerStandService_WriteTrack_Ans>::Pointer ctx);
  986. bool GetWaitFlag(){return m_bWaitingAccept;}
  987. void SetWaitMore(){m_bWaitAccepteMore = true;}
  988. void SetExitFlag(bool bFlag=true){m_bExit = bFlag;}
  989. bool FSMSetIssueFlag(int value=1);
  990. void FrontSetIssueFlag(bool bValue = true){ FSMSetIssueFlag(bValue); }
  991. int QueryIssueFlag(){ return m_issueStatus; }
  992. bool SetCardCaptured(const int num,bool bNewClear=false);
  993. bool SetCardIssued(const int num,const int hopper);
  994. bool SetCardRemains(const int num, const int hopper,bool bInit = false);
  995. bool SetCardMixed(const int num, const int hopper);
  996. ErrorCodeEnum MachineMoveCardBackNotHold();
  997. ErrorCodeEnum MachineMoveCardFrontGate(bool bInBussiness=false);
  998. void SelfTest(EntityTestEnum eTestType,CSmartPointer<ITransactionContext> pTransactionContext);
  999. DevStateEnum GetDevState() const
  1000. {
  1001. if ((m_eDevState == DEVICE_STATUS_NORMAL)
  1002. && ((m_bHasHopper[0] && m_mixedEx[0] >= 3) || !m_bHasHopper[0])
  1003. && ((m_bHasHopper[1] && m_mixedEx[1] >= 3) || !m_bHasHopper[1])
  1004. && ((m_bHasHopper[2] && m_mixedEx[2] >= 3) || !m_bHasHopper[2]))
  1005. return DEVICE_STATUS_MAINTAINCE;
  1006. else
  1007. return m_eDevState;
  1008. }
  1009. int QueryCardInfo();
  1010. int UpdateLocalRunCfg(CAutoArray<int> hopperArr);
  1011. int SyncDataToDB(bool bMaintain[12],bool bSetCaptured=true);//同步物料计数
  1012. void SetHopperNum(int hopperNum);
  1013. void DoExitWhenIdle();
  1014. int SAMICCommand(SpReqAnsContext<CardIssuerStandService_SAMICCommand_Req, CardIssuerStandService_SAMICCommand_Ans>::Pointer ctx);
  1015. bool WriteCardInfo(CSmartPointer<IConfigInfo> &cfgRun, const char *acc, const char* serial, int slot, bool bClear = false, bool bHasCard = false);
  1016. bool ReadCardInfo(CSmartPointer<IConfigInfo> &cfgRun, CSimpleStringA &acc, CSimpleStringA &serial, int slot);
  1017. void DecodeTracksData(const char *track2, DWORD dwT2size, const char *track3, DWORD dwT3size,char *&magData,bool bT2OK=true,bool bT3OK=true);
  1018. int GetFSMState()
  1019. {
  1020. //DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)(CSimpleStringA::Format("m_currentFSMState:%d", m_currentFSMState));
  1021. return m_currentFSMState;
  1022. }
  1023. void GetCardInfo(int &findCard, int &cardPos)
  1024. {
  1025. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)(CSimpleStringA::Format("<GetCardInfo>, findCard:%d, cardPos:%d", findCard, cardPos));
  1026. findCard = m_findCard;
  1027. cardPos = m_cardPos;
  1028. }
  1029. int SplitDevModelInfo();
  1030. void SetCancelByRFICFlag(bool bCancel = true) { m_bCancelByRFIC = bCancel; }
  1031. CSimpleStringA GetPreOnlineICCardNo() { return m_currCardNo; }
  1032. void CloseAndClearDevObj(bool bCheckConnecting = true, bool bCloseOnly = false);
  1033. void SetEnterMainPage();
  1034. static void HttpsLogCallBack(const char* logtxt);
  1035. //0:unknow(havn't access microservice or access failed),1:both mag & ic ,2:mag only,3:ic only
  1036. int JudgeCardType(CSimpleStringA cardno, bool &bMismatch);
  1037. void QueryCIStatus(SpReqAnsContext<CardIssuerStandService_QueryCIStatus_Req, CardIssuerStandService_QueryCIStatus_Ans>::Pointer ctx);
  1038. bool RegistCardWhileCaptureCard(CSimpleStringA cardno);
  1039. bool SyncMaterialCount(IHttpFunc* client,SyncMaterialCountInfo syncInfo);
  1040. protected:
  1041. int m_iInsertTries;
  1042. int m_resetTries;
  1043. int m_ejectTries;
  1044. private:
  1045. ///
  1046. int m_resetTimes;
  1047. lpCMBdecodeMag2 cmdDecodeMag2;
  1048. lpCMBdecodeEx cmdDecodeEx;
  1049. bool m_bCancelAccept, m_bWaitingAccept, m_bWaitAccepteMore, m_bExit
  1050. , m_bCDA, m_bIssuingExit, m_bCardIssued, m_bHasHopper[HOPPER_NUM]
  1051. , m_bSettingMaterial, m_hasCardWhileDevOpen, m_bCancelByRFIC
  1052. , m_bCardActiveNotify, m_bCardFromHopper, m_bUseCardnoMismatch, m_bStopUseRF;
  1053. bool m_bUseRFTillNext;//if ReadCard by RF,the following PreOnline & PostOnline always use RF till the next card(insert/issue)
  1054. ErrorCodeEnum m_testResult;
  1055. int m_CardCaptured;
  1056. int m_issueStatusFromFile, m_issueStatus/*the status maybe changed by Business call*/;
  1057. //1:default, 2:SCI, 3:no cfg
  1058. int m_machineType;
  1059. WORD m_majorVerion, m_minorVerion;
  1060. int m_currentHopper,m_devOpenFailedCount;
  1061. int m_maxSlot,m_findCard,m_cardPos,m_currentFSMState,m_maxRetainCount, m_eacQueryFlag/*accout query*/
  1062. ,m_ICRetryTimes;
  1063. CSimpleStringA m_CardBoxNoEx[HOPPER_NUM], m_PsbCodeEx[HOPPER_NUM], m_PsbNameEx[HOPPER_NUM], m_MaintainerEx[HOPPER_NUM],m_csMaintainTimeEx[HOPPER_NUM];
  1064. int m_CardInitEx[HOPPER_NUM], m_CardPercentEx[HOPPER_NUM], m_remainsEx[HOPPER_NUM], m_issuedEx[HOPPER_NUM], m_mixedEx[HOPPER_NUM],m_hopperNum;
  1065. DWORD m_MaintainTimeEx[HOPPER_NUM];
  1066. BYTE m_connectType, m_r1[128], m_r2[128], m_r3[128], m_priKey[ONE_K / 2], m_devPubKey[ONE_K / 2];
  1067. CardIssuerStatus m_devStatus;
  1068. CCardProcess *m_pCardProcess;
  1069. CAutoArray<CSimpleStringA> m_aidList;
  1070. char *m_pDataToARQC;
  1071. long xxTest;
  1072. CSimpleStringA m_currCardNo, m_captureReason, m_csMachineType, m_terminalNo, m_addCardNo, m_addCardSerial, m_rfVendorList, m_csRF;
  1073. char m_AuthCode[2];
  1074. vector<CMBBin> m_vBin;
  1075. int SplitTrack2(CSimpleStringA pTrack2,Track2Data &decodeData);
  1076. bool JustReadCardNo();
  1077. bool IsValidCardNo(const char*,int);
  1078. void GetVendorDllName(CSimpleStringA &dllName);
  1079. bool AccountExchange(const char *origAcc, CSimpleStringA &acc,int dir=1);
  1080. bool LoadCMBPrint(CSimpleStringA csBinPath);
  1081. DevCategoryInfo m_devCat;
  1082. bool ToRegistCaptureCardInfo();
  1083. bool IfUseRf();
  1084. CSimpleStringA m_EacQueryHost, m_csSwallowCardUrl, m_csSyncMaterialUrl;
  1085. MagTracks m_magTracks;
  1086. public:
  1087. int EjectJS(SpReqAnsContext<CardIssuerStandService_EjectJS_Req, CardIssuerStandService_EjectJS_Ans>::Pointer ctx);
  1088. int CaptureJS(SpReqAnsContext<CardIssuerStandService_CaptureJS_Req, CardIssuerStandService_CaptureJS_Ans>::Pointer ctx);
  1089. void QueryHasCardJS(SpReqAnsContext<CardIssuerStandService_QueryHasCardJS_Req, CardIssuerStandService_QueryHasCardJS_Ans>::Pointer ctx);
  1090. int PostOnlineJS(SpReqAnsContext<CardIssuerStandService_PostOnlineJS_Req, CardIssuerStandService_PostOnlineJS_Ans>::Pointer ctx);
  1091. int IssueFromBoxJS(SpReqAnsContext<CardIssuerStandService_IssueFromBoxJS_Req, CardIssuerStandService_IssueFromBoxJS_Ans>::Pointer ctx);
  1092. int ReadJS(SpReqAnsContext<CardIssuerStandService_ReadJS_Req, CardIssuerStandService_ReadJS_Ans>::Pointer ctx);
  1093. int InsertJS(SpReqAnsContext<CardIssuerStandService_InsertJS_Req, CardIssuerStandService_InsertJS_Ans>::Pointer ctx);
  1094. int InternalInsert();
  1095. int PostOnlineJS_Contact(SpReqAnsContext<CardIssuerStandService_PostOnlineJS_Req, CardIssuerStandService_PostOnlineJS_Ans>::Pointer ctx, bool& bICOK);
  1096. int PostOnlineJS_RF(SpReqAnsContext<CardIssuerStandService_PostOnlineJS_Req, CardIssuerStandService_PostOnlineJS_Ans>::Pointer ctx);
  1097. int ReadMag(SpReqAnsContext<CardIssuerStandService_ReadJS_Req, CardIssuerStandService_ReadJS_Ans>::Pointer ctx, bool& bReadCardInfo, bool& bReadMag, CSimpleStringA& t2Account);
  1098. int CheckCardType(CSimpleStringA cardNo, bool bReadMag, int& ICtype);
  1099. int PreOnlineJS_Contact(SpReqAnsContext<CardIssuerStandService_ReadJS_Req, CardIssuerStandService_ReadJS_Ans>::Pointer ctx, bool& bICOK, bool& bContinue);
  1100. int PreOnlineJS_RF(SpReqAnsContext<CardIssuerStandService_ReadJS_Req, CardIssuerStandService_ReadJS_Ans>::Pointer ctx);
  1101. DWORD GetFsmStateErrCode();
  1102. CSimpleStringA MaskCardno(const char* cardno);
  1103. void GetCardProcessLastErr(ErrorCodeEnum& eErrCode, CSimpleStringA& lastApiName, CSimpleStringA& alarmMsg, CSimpleStringA& csErrMsgWithReturnCode);
  1104. int QuickSelfCheckImpl();
  1105. void setQuickSelfCheck() {
  1106. m_quickSelfcheck = true;
  1107. }
  1108. void SetDoExitFlag(bool bFlag) { m_bDoExit = bFlag; }
  1109. int PowerOffIC(int type);//0:接触IC 1:非接
  1110. private:
  1111. bool m_bCancelInsert;
  1112. bool m_quickSelfcheck;
  1113. bool m_bDoExit;
  1114. bool m_bReturnMainPage;//正在处理过程中是否退到首页变量
  1115. public:
  1116. int m_SelfcheckSleepTime;
  1117. };
  1118. struct InitTask : public ITaskSp
  1119. {
  1120. CCardIssuerFSM* fsm;
  1121. InitTask(CCardIssuerFSM* f) : fsm(f) {}
  1122. void Process()
  1123. {
  1124. FSMEvent *e = new FSMEvent(USER_EVT_INITFINISHED);
  1125. e->param1 = fsm->Initial();
  1126. fsm->PostEventFIFO(e);
  1127. }
  1128. };
  1129. struct AcceptTask : public ITaskSp
  1130. {
  1131. CCardIssuerFSM* fsm;
  1132. SpReqAnsContext<CardIssuerStandService_Insert_Req, CardIssuerStandService_Insert_Ans>::Pointer ctx;
  1133. AcceptTask(CCardIssuerFSM* f) : fsm(f) {}
  1134. void Process()
  1135. {
  1136. LOG_FUNCTION();
  1137. FSMEvent *e = new FSMEvent(USER_EVT_ACCEPTFINISHED);
  1138. e->param1 = fsm->AcceptCard(ctx);
  1139. fsm->PostEventFIFO(e);
  1140. }
  1141. };
  1142. struct IssueTask : public ITaskSp
  1143. {
  1144. CCardIssuerFSM* fsm;
  1145. SpReqAnsContext<CardIssuerStandService_Issue_Req, CardIssuerStandService_Issue_Ans>::Pointer ctx;
  1146. SpReqAnsContext<CardIssuerStandService_IssueEx_Req, CardIssuerStandService_IssueEx_Ans>::Pointer ctxEx;
  1147. IssueTask(CCardIssuerFSM* f) : fsm(f) {}
  1148. void Process()
  1149. {
  1150. LOG_FUNCTION();
  1151. FSMEvent *e;
  1152. if (ctx != NULL)
  1153. e = new FSMEvent(USER_EVT_ISSUE_FINISHED);
  1154. else if (ctxEx != NULL)
  1155. e = new FSMEvent(USER_EVT_ISSUE_EX_FINISHED);
  1156. else
  1157. {
  1158. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("IssueTask:ctx is null");
  1159. return;
  1160. }
  1161. e->param1 = fsm->IssueCard(ctx,ctxEx);
  1162. fsm->PostEventFIFO(e);
  1163. }
  1164. };
  1165. struct ReadTask : public ITaskSp
  1166. {
  1167. SpReqAnsContext<CardIssuerStandService_Read_Req,CardIssuerStandService_Read_Ans>::Pointer ctx;
  1168. CCardIssuerFSM* fsm;
  1169. ReadTask(CCardIssuerFSM* f) : fsm(f) {}
  1170. void Process()
  1171. {
  1172. CardReadFinishedEvent *e = new CardReadFinishedEvent();
  1173. e->ctx = ctx;
  1174. e->param1 = fsm->ReadCard(ctx);
  1175. fsm->PostEventFIFO(e);
  1176. }
  1177. };
  1178. struct PreOnlineTask : public ITaskSp
  1179. {
  1180. SpReqAnsContext<CardIssuerStandService_PreOnline_Req,CardIssuerStandService_PreOnline_Ans>::Pointer ctx;
  1181. CCardIssuerFSM* fsm;
  1182. PreOnlineTask(CCardIssuerFSM* f) : fsm(f) {}
  1183. void Process()
  1184. {
  1185. FSMEvent *e = new FSMEvent(USER_EVT_PREONLINEFINISHED);
  1186. e->param1 = fsm->PreOnline(ctx);//oilyang@20220611 实际上,为简化处理,PreOnline函数默认返回0
  1187. fsm->PostEventFIFO(e);
  1188. }
  1189. };
  1190. struct PostOnlineTask : public ITaskSp
  1191. {
  1192. SpReqAnsContext<CardIssuerStandService_PostOnline_Req,CardIssuerStandService_PostOnline_Ans>::Pointer ctx;
  1193. CCardIssuerFSM* fsm;
  1194. PostOnlineTask(CCardIssuerFSM* f) : fsm(f) {}
  1195. void Process()
  1196. {
  1197. FSMEvent *e = new FSMEvent(USER_EVT_POSTONLINEFINISHED);
  1198. e->param1 = fsm->PostOnline(ctx);
  1199. fsm->PostEventFIFO(e);
  1200. }
  1201. };
  1202. struct CaptureTask : public ITaskSp
  1203. {
  1204. CCardIssuerFSM* fsm;
  1205. SpReqAnsContext<CardIssuerStandService_Capture_Req,CardIssuerStandService_Capture_Ans>::Pointer ctx;
  1206. CaptureTask(CCardIssuerFSM* f) : fsm(f) {}
  1207. void Process()
  1208. {
  1209. FSMEvent *e = new FSMEvent(USER_EVT_CAPTUREFINISHED);
  1210. e->param1 = fsm->CaptureCard(ctx);
  1211. fsm->PostEventFIFO(e);
  1212. }
  1213. };
  1214. struct EjectTask : public ITaskSp
  1215. {
  1216. SpReqAnsContext<CardIssuerStandService_Eject_Req,CardIssuerStandService_Eject_Ans>::Pointer ctx;
  1217. CCardIssuerFSM* fsm;
  1218. EjectTask(CCardIssuerFSM* f) : fsm(f) {}
  1219. void Process()
  1220. {
  1221. FSMEvent *e = new FSMEvent(USER_EVT_EJECTFINISHED);
  1222. e->param1 = fsm->EjectCard(ctx);
  1223. fsm->PostEventFIFO(e);
  1224. }
  1225. };
  1226. struct WaitFetchingTask : public ITaskSp
  1227. {
  1228. CCardIssuerFSM* fsm;
  1229. WaitFetchingTask(CCardIssuerFSM* f) : fsm(f) {}
  1230. void Process()
  1231. {
  1232. FSMEvent *e = new FSMEvent(USER_EVT_WAITFINISHED);
  1233. e->param1 = fsm->WaitFetchingCard();
  1234. fsm->PostEventFIFO(e);
  1235. }
  1236. };
  1237. struct ResetTask : public ITaskSp
  1238. {
  1239. CCardIssuerFSM* fsm;
  1240. ResetTask(CCardIssuerFSM* f) : fsm(f) {}
  1241. void Process()
  1242. {
  1243. ResetFinishedEvent *e = new ResetFinishedEvent();
  1244. e->param1 = fsm->Reset();
  1245. fsm->PostEventFIFO(e);
  1246. }
  1247. };
  1248. struct WriteTask : public ITaskSp
  1249. {
  1250. SpReqAnsContext<CardIssuerStandService_WriteTrack_Req,CardIssuerStandService_WriteTrack_Ans>::Pointer ctx;
  1251. CCardIssuerFSM* fsm;
  1252. WriteTask(CCardIssuerFSM* f) : fsm(f) {}
  1253. void Process()
  1254. {
  1255. CardWriteFinishedEvent *e = new CardWriteFinishedEvent();
  1256. e->ctx = ctx;
  1257. e->param1 = fsm->WriteCard(ctx);
  1258. fsm->PostEventFIFO(e);
  1259. }
  1260. };
  1261. struct DoExitWhenIdleTask : public ITaskSp
  1262. {
  1263. CCardIssuerFSM* fsm;
  1264. DoExitWhenIdleTask(CCardIssuerFSM* f) : fsm(f) {}
  1265. void Process()
  1266. {
  1267. fsm->DoExitWhenIdle();
  1268. fsm->SetDoExitFlag(false);
  1269. }
  1270. };
  1271. struct SAMICCommandTask : public ITaskSp
  1272. {
  1273. CCardIssuerFSM* fsm;
  1274. SpReqAnsContext<CardIssuerStandService_SAMICCommand_Req, CardIssuerStandService_SAMICCommand_Ans>::Pointer ctx;
  1275. SAMICCommandTask(CCardIssuerFSM* f) : fsm(f) {}
  1276. void Process()
  1277. {
  1278. FSMEvent* e = new FSMEvent(USER_EVT_SAM_IC_FINISHED);
  1279. e->param1 = fsm->SAMICCommand(ctx);
  1280. fsm->PostEventFIFO(e);
  1281. }
  1282. };
  1283. struct RegistCaptureCardInfoTask : public ITaskSp
  1284. {
  1285. CCardIssuerFSM* fsm;
  1286. CSimpleStringA cardno;
  1287. RegistCaptureCardInfoTask(CCardIssuerFSM* f, CSimpleStringA cardno) : fsm(f),cardno(cardno) {}
  1288. void Process()
  1289. {
  1290. fsm->RegistCardWhileCaptureCard(cardno);
  1291. }
  1292. };
  1293. struct SyncMaterialCountTask : public ITaskSp
  1294. {
  1295. CCardIssuerFSM* fsm;
  1296. SyncMaterialCountInfo syncInfo;
  1297. SyncMaterialCountTask(CCardIssuerFSM* f, SyncMaterialCountInfo syncMaterialInfo){
  1298. fsm = f;
  1299. syncInfo = syncMaterialInfo;
  1300. }
  1301. void Process()
  1302. {
  1303. LOG_FUNCTION();
  1304. //同步物料信息
  1305. IHttpFunc* client;
  1306. client = create_http(fsm->HttpsLogCallBack);
  1307. bool ret = fsm->SyncMaterialCount(client,syncInfo);
  1308. client->Destory();
  1309. }
  1310. };
  1311. #pragma region JS接口 工作线程
  1312. //吐卡
  1313. struct EjectJSTask : public ITaskSp
  1314. {
  1315. CCardIssuerFSM* fsm;
  1316. SpReqAnsContext<CardIssuerStandService_EjectJS_Req, CardIssuerStandService_EjectJS_Ans>::Pointer ctx;
  1317. EjectJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1318. void Process()
  1319. {
  1320. FSMEvent* e = new FSMEvent(USER_EVT_JS_EJECT_FINISHED);
  1321. e->param1 = fsm->EjectJS(ctx);
  1322. fsm->PostEventFIFO(e);
  1323. }
  1324. };
  1325. //吞卡
  1326. struct CaptureJSTask : public ITaskSp
  1327. {
  1328. CCardIssuerFSM* fsm;
  1329. SpReqAnsContext<CardIssuerStandService_CaptureJS_Req, CardIssuerStandService_CaptureJS_Ans>::Pointer ctx;
  1330. CaptureJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1331. void Process()
  1332. {
  1333. FSMEvent* e = new FSMEvent(USER_EVT_JS_CAPTURE_FINISHED);
  1334. e->param1 = fsm->CaptureJS(ctx);
  1335. fsm->PostEventFIFO(e);
  1336. }
  1337. };
  1338. //联机后处理
  1339. struct PostOnlineJSTask : public ITaskSp
  1340. {
  1341. CCardIssuerFSM* fsm;
  1342. SpReqAnsContext<CardIssuerStandService_PostOnlineJS_Req, CardIssuerStandService_PostOnlineJS_Ans>::Pointer ctx;
  1343. PostOnlineJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1344. void Process()
  1345. {
  1346. FSMEvent* e = new FSMEvent(USER_EVT_JS_POSTONLINE_FINISHED);
  1347. e->param1 = fsm->PostOnlineJS(ctx);
  1348. fsm->PostEventFIFO(e);
  1349. }
  1350. };
  1351. //卡箱发卡
  1352. struct IssueFromBoxJSTask : public ITaskSp
  1353. {
  1354. CCardIssuerFSM* fsm;
  1355. SpReqAnsContext<CardIssuerStandService_IssueFromBoxJS_Req, CardIssuerStandService_IssueFromBoxJS_Ans>::Pointer ctx;
  1356. IssueFromBoxJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1357. void Process()
  1358. {
  1359. FSMEvent* e = new FSMEvent(USER_EVT_JS_ISSUE_FROM_BOX_FINISHED);
  1360. e->param1 = fsm->IssueFromBoxJS(ctx);
  1361. fsm->PostEventFIFO(e);
  1362. }
  1363. };
  1364. //读卡
  1365. struct ReadJSTask : public ITaskSp
  1366. {
  1367. CCardIssuerFSM* fsm;
  1368. SpReqAnsContext<CardIssuerStandService_ReadJS_Req, CardIssuerStandService_ReadJS_Ans>::Pointer ctx;
  1369. ReadJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1370. void Process()
  1371. {
  1372. FSMEvent* e = new FSMEvent(USER_EVT_JS_READ_FINISHED);
  1373. e->param1 = fsm->ReadJS(ctx);
  1374. fsm->PostEventFIFO(e);
  1375. }
  1376. };
  1377. struct InsertJSTask : public ITaskSp
  1378. {
  1379. CCardIssuerFSM* fsm;
  1380. SpReqAnsContext<CardIssuerStandService_InsertJS_Req, CardIssuerStandService_InsertJS_Ans>::Pointer ctx;
  1381. InsertJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1382. void Process()
  1383. {
  1384. LOG_FUNCTION();
  1385. FSMEvent* e = new FSMEvent(USER_EVT_JS_INSERT_FINISHED);
  1386. e->param1 = fsm->InsertJS(ctx);
  1387. fsm->PostEventFIFO(e);
  1388. }
  1389. };
  1390. //故障自检task
  1391. struct QuickSelfcheckTask : public ITaskSp
  1392. {
  1393. CCardIssuerFSM* fsm;
  1394. QuickSelfcheckTask(CCardIssuerFSM* f) : fsm(f) {}
  1395. void Process()
  1396. {
  1397. QuickSelfcheckFinishEvent* e = new QuickSelfcheckFinishEvent();
  1398. Sleep(fsm->m_SelfcheckSleepTime);
  1399. e->param1 = fsm->QuickSelfCheckImpl();
  1400. fsm->PostEventFIFO(e);
  1401. }
  1402. };
  1403. #pragma endregion JS接口 工作线程
  1404. #endif //__CARD_ISSUER_FSM_H