CardIssuerStandFSM.h 40 KB

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