CardIssuerFSM.h 41 KB

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