CardIssuerStoreFSM.h 68 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998
  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 "HealthManager_client_g.h"
  9. #include "DevFSMCommBase.hpp"
  10. #include "CardIssuerClass.h"
  11. #include "CardAssist.h"
  12. #include "ICDataElement.h"
  13. #include "IHttpFunc.h"
  14. //#include "publicFunExport.h"
  15. #include "json/json.h"
  16. #include "CardIssuerStore_UserErrorCode.h" //后续替代EventCode.h,暂时混合使用,时间太紧
  17. #define REFLECTION(var) #var
  18. using namespace CardIssuerStore;
  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_EJECT,
  28. USER_EVT_CAPTURE,
  29. USER_EVT_EJECTFINISHED,
  30. USER_EVT_WAITFINISHED,
  31. USER_EVT_CAPTUREFINISHED,
  32. USER_EVT_WAITFETCHINGTIMEOUT,
  33. USER_EVT_PREONLINE,
  34. USER_EVT_POSTONLINE,
  35. USER_EVT_PREONLINEFINISHED,
  36. USER_EVT_POSTONLINEFINISHED,
  37. USER_EVT_RESET,
  38. USER_EVT_RESETFINISHED,
  39. USER_EVT_EXIT,
  40. USER_EVT_READ,
  41. USER_EVT_READ_FINISHED,
  42. USER_EVT_WRITE,
  43. USER_EVT_WRITE_FINISHED,
  44. USER_EVT_GET_MATERIAL_EX,
  45. USER_EVT_SET_MATERIAL_EX,
  46. USER_EVT_ISSUE_EX,
  47. USER_EVT_ISSUE_EX_FINISHED,
  48. USER_EVT_SAM_IC,
  49. USER_EVT_SAM_IC_FINISHED,
  50. USER_EVT_QUERY_PRINT_STATUS,
  51. USER_EVT_QUERY_PRINT_STATUS_FINISHED,
  52. USER_EVT_BACK_TO_INIT,
  53. USER_EVT_QUERYCARDINFO_ON_STORE,
  54. USER_EVT_QUERYCARDINFO_ON_STORE_FINISHED,
  55. USER_EVT_PRINT_CARD_IM,
  56. USER_EVT_PRINT_CARD_IM_FINISHED,
  57. //新定义JS状态机事件枚举
  58. USER_EVT_JS_READ_BATCHCARDINFO_IN_RANGE = EVT_USER + 38,
  59. USER_EVT_JS_READ_BATCHCARDINFO_IN_RANGE_FINISHED,
  60. USER_EVT_JS_CAPTURE,
  61. USER_EVT_JS_CAPTURE_FINISHED,
  62. USER_EVT_JS_ADD_AND_READ_CRAD_FROMBOX,
  63. USER_EVT_JS_ADD_AND_READ_CRAD_FROMBOX_FINISHED,
  64. USER_EVT_JS_MOVE_AND_READ_CARD_FROMSLOT,
  65. USER_EVT_JS_MOVE_AND_READ_CARD_FROMSLOT_FINISHED,
  66. USER_EVT_JS_MOVEBACK_TO_SLOT,
  67. USER_EVT_JS_MOVEBACK_TO_SLOT_FINISHED,
  68. USER_EVT_JS_ISSUE_FROM_SLOT,
  69. USER_EVT_JS_ISSUE_FROM_SLOT_FINISHED,
  70. USER_EVT_JS_EJECT,
  71. USER_EVT_JS_EJECT_FINISHED,
  72. USER_EVT_JS_WRITE_TRACK,
  73. USER_EVT_JS_WRITE_TRACK_FINISHED,
  74. USER_EVT_JS_PRINT_CARD,
  75. USER_EVT_JS_PRINT_CARD_FINISHED,
  76. USER_EVT_JS_SAM_IC_COMMAND,
  77. USER_EVT_JS_SAM_IC_COMMAND_FINISHED,
  78. USER_EVT_JS_POSTONLINE,
  79. USER_EVT_JS_POSTONLINE_FINISHED,
  80. USER_EVT_JS_ISSUE_FROM_BOX,
  81. USER_EVT_JS_ISSUE_FROM_BOX_FINISHED,
  82. USER_EVT_JS_PREONLINE_CROSS,
  83. USER_EVT_JS_PREONLINE_CROSS_FINISHED,
  84. USER_EVT_QUICK_SELF_CHECK,
  85. USER_EVT_QUICK_SELF_CHECK_FINISHED,
  86. USER_EVT_JS_READ,
  87. USER_EVT_JS_READ_FINISHED,
  88. USER_EVT_JS_ADD_CRAD_FROMBOX,
  89. USER_EVT_JS_ADD_CRAD_FROMBOX_FINISHED,
  90. USER_EVT_JS_MOVE_CARD_FROMSLOT,
  91. USER_EVT_JS_MOVE_CARD_FROMSLOT_FINISHED,
  92. };
  93. enum SAMICCommandType
  94. {
  95. //SAM
  96. SAMICCommand_SAM_Select = 0,
  97. SAMICCommand_SAM_Active,
  98. SAMICCommand_SAM_Deactivate,
  99. SAMICCommand_SAM_WarmReset,
  100. SAMICCommand_SAM_QueryStatus,
  101. SAMICCommand_SAM_Command,
  102. //IC
  103. SAMICCommand_IC_Active = 100,
  104. SAMICCommand_IC_Deactivate,
  105. SAMICCommand_IC_WarmReset,
  106. SAMICCommand_IC_Command,
  107. SAMICCommand_RFIC_Active,
  108. SAMICCommand_RFIC_Deactivate,
  109. SAMICCommand_RFIC_Command,
  110. };
  111. enum CardResultType
  112. {
  113. CardResult_Invalid_Slot = 1,
  114. CardResult_HaveNoCardInTheSlot,
  115. CardResult_Account_MisMatch,
  116. CardResult_ReadAccount_Fail,
  117. CardResult_CanNotFindEmptySlot,
  118. CardResult_MoveToCardReader_Fail,
  119. CardResult_MoveToSlot_Fail
  120. };
  121. enum CardPositionType
  122. {
  123. CardPos_KeepInCardReader = 0,
  124. CardPos_HaveMovedToSlot = 1,
  125. CardPos_HaveCapturedCard =3,
  126. CardPos_HaveEjectedCard =4
  127. };
  128. typedef int(*lpCMBdecodeMag2)(char* Mag2Data, char * data);
  129. typedef int(*lpCMBdecodeEx)( char* MagData, char * type, char * data);
  130. typedef int(__stdcall *pfEncryptDukptHSM)(unsigned char* EncryptedData, unsigned char* bdk, unsigned char* curksn, unsigned char* DecryptedData);
  131. typedef int(__stdcall *pfGetEncrypedData)(unsigned char* BDK, unsigned char* KSN, unsigned char*random, unsigned char* result);
  132. class CCardIssuerEntity;
  133. class CCardIssuerFSM;
  134. const int ONE_K = 1024;
  135. const int HOPPER_NUM = 12;
  136. struct Track2Data
  137. {
  138. int status;
  139. CSimpleStringA t2Account;
  140. CSimpleStringA t2Region;
  141. CSimpleStringA t2CardSerial;
  142. CSimpleStringA t2CVC;
  143. CSimpleStringA t2ExpireDate;
  144. };
  145. struct CMBBin
  146. {
  147. CSimpleStringA bin;//6 byte long
  148. bool bIC;//IC:true or mag:false
  149. bool bDC;//debit:true,credit:false
  150. };
  151. class CardInitFinishedEvent : public FSMEvent
  152. {
  153. public:
  154. CardInitFinishedEvent() : FSMEvent(USER_EVT_INITFINISHED){}
  155. ~CardInitFinishedEvent(){}
  156. SpReqAnsContext<CardIssuerStoreService_Insert_Req,CardIssuerStoreService_Insert_Ans>::Pointer ctx;
  157. protected:
  158. private:
  159. };
  160. class QueryCardInfoOnStoreEvent : public FSMEvent
  161. {
  162. public:
  163. QueryCardInfoOnStoreEvent() : FSMEvent(USER_EVT_QUERYCARDINFO_ON_STORE) {}
  164. ~QueryCardInfoOnStoreEvent() {}
  165. SpReqAnsContext<CardIssuerStoreService_QueryCardInfoOnStore_Req, CardIssuerStoreService_QueryCardInfoOnStore_Ans>::Pointer ctx;
  166. virtual void OnUnhandled()
  167. {
  168. if (ctx != NULL)
  169. {
  170. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("Operate CardStore unhandled");
  171. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  172. }
  173. }
  174. };
  175. class CardReadEvent : public FSMEvent
  176. {
  177. public:
  178. CardReadEvent() : FSMEvent(USER_EVT_READ) {}
  179. ~CardReadEvent() {}
  180. SpReqAnsContext<CardIssuerStoreService_Read_Req, CardIssuerStoreService_Read_Ans>::Pointer ctx;
  181. virtual void OnUnhandled()
  182. {
  183. if (ctx != NULL)
  184. {
  185. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("card read unhandled");
  186. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  187. }
  188. }
  189. protected:
  190. private:
  191. };
  192. class CardReadFinishedEvent : public FSMEvent
  193. {
  194. public:
  195. CardReadFinishedEvent() : FSMEvent(USER_EVT_READ_FINISHED) {}
  196. ~CardReadFinishedEvent() {}
  197. SpReqAnsContext<CardIssuerStoreService_Read_Req, CardIssuerStoreService_Read_Ans>::Pointer ctx;
  198. virtual void OnUnhandled()
  199. {
  200. if (ctx != NULL)
  201. {
  202. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("card read unhandled(new)");
  203. }
  204. }
  205. protected:
  206. private:
  207. };
  208. class ResetDeviceEvent : public FSMEvent
  209. {
  210. public:
  211. ResetDeviceEvent() : FSMEvent(USER_EVT_RESET){}
  212. ~ResetDeviceEvent(){}
  213. protected:
  214. private:
  215. };
  216. class ResetFinishedEvent : public FSMEvent
  217. {
  218. public:
  219. ResetFinishedEvent() : FSMEvent(USER_EVT_RESETFINISHED){}
  220. ~ResetFinishedEvent(){}
  221. protected:
  222. private:
  223. };
  224. class PreOnlineEvent : public FSMEvent
  225. {
  226. public:
  227. PreOnlineEvent() : FSMEvent(USER_EVT_PREONLINE){}
  228. ~PreOnlineEvent(){}
  229. SpReqAnsContext<CardIssuerStoreService_PreOnline_Req,CardIssuerStoreService_PreOnline_Ans>::Pointer ctx;
  230. virtual void OnUnhandled()
  231. {
  232. if (ctx != NULL)
  233. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  234. }
  235. protected:
  236. private:
  237. };
  238. class PostOnlineEvent : public FSMEvent
  239. {
  240. public:
  241. PostOnlineEvent() : FSMEvent(USER_EVT_POSTONLINE){}
  242. ~PostOnlineEvent(){}
  243. SpReqAnsContext<CardIssuerStoreService_PostOnline_Req,CardIssuerStoreService_PostOnline_Ans>::Pointer ctx;
  244. virtual void OnUnhandled()
  245. {
  246. if (ctx != NULL)
  247. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  248. }
  249. protected:
  250. private:
  251. };
  252. class CardCaptureEvent : public FSMEvent
  253. {
  254. public:
  255. CardCaptureEvent() : FSMEvent(USER_EVT_CAPTURE){}
  256. ~CardCaptureEvent(){}
  257. SpReqAnsContext<CardIssuerStoreService_Capture_Req,CardIssuerStoreService_Capture_Ans>::Pointer ctx;
  258. virtual void OnUnhandled()
  259. {
  260. if (ctx != NULL)
  261. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  262. }
  263. protected:
  264. private:
  265. };
  266. class CardEjectEvent : public FSMEvent
  267. {
  268. public:
  269. CardEjectEvent() : FSMEvent(USER_EVT_EJECT){}
  270. ~CardEjectEvent(){}
  271. SpReqAnsContext<CardIssuerStoreService_Eject_Req,CardIssuerStoreService_Eject_Ans>::Pointer ctx;
  272. virtual void OnUnhandled()
  273. {
  274. if (ctx != NULL)
  275. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  276. }
  277. protected:
  278. private:
  279. };
  280. class CardWriteEvent : public FSMEvent
  281. {
  282. public:
  283. CardWriteEvent() : FSMEvent(USER_EVT_WRITE){}
  284. ~CardWriteEvent(){}
  285. SpReqAnsContext<CardIssuerStoreService_WriteTrack_Req,CardIssuerStoreService_WriteTrack_Ans>::Pointer ctx;
  286. virtual void OnUnhandled()
  287. {
  288. if (ctx != NULL)
  289. {
  290. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("card Write unhandled");
  291. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  292. }
  293. }
  294. protected:
  295. private:
  296. };
  297. class CardWriteFinishedEvent : public FSMEvent
  298. {
  299. public:
  300. CardWriteFinishedEvent() : FSMEvent(USER_EVT_WRITE_FINISHED){}
  301. ~CardWriteFinishedEvent(){}
  302. SpReqAnsContext<CardIssuerStoreService_WriteTrack_Req,CardIssuerStoreService_WriteTrack_Ans>::Pointer ctx;
  303. virtual void OnUnhandled()
  304. {
  305. if (ctx != NULL)
  306. {
  307. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("card Write unhandled(new)");
  308. }
  309. }
  310. protected:
  311. private:
  312. };
  313. class GetMaterialExEvent : public FSMEvent
  314. {
  315. public:
  316. GetMaterialExEvent() : FSMEvent(USER_EVT_GET_MATERIAL_EX){}
  317. ~GetMaterialExEvent(){}
  318. SpReqAnsContext<CardIssuerStoreService_GetMaterialCountEx_Req, CardIssuerStoreService_GetMaterialCountEx_Ans>::Pointer ctx;
  319. virtual void OnUnhandled()
  320. {
  321. if (ctx != NULL)
  322. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  323. }
  324. protected:
  325. private:
  326. };
  327. class SetMaterialExEvent : public FSMEvent
  328. {
  329. public:
  330. SetMaterialExEvent() : FSMEvent(USER_EVT_SET_MATERIAL_EX){}
  331. ~SetMaterialExEvent(){}
  332. SpReqAnsContext<CardIssuerStoreService_SetMaterialCountEx_Req, CardIssuerStoreService_SetMaterialCountEx_Ans>::Pointer ctx;
  333. virtual void OnUnhandled()
  334. {
  335. if (ctx != NULL)
  336. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  337. }
  338. protected:
  339. private:
  340. };
  341. class CardIssueExEvent : public FSMEvent
  342. {
  343. public:
  344. CardIssueExEvent() : FSMEvent(USER_EVT_ISSUE_EX){}
  345. ~CardIssueExEvent(){}
  346. SpReqAnsContext<CardIssuerStoreService_IssueEx_Req, CardIssuerStoreService_IssueEx_Ans>::Pointer ctx;
  347. virtual void OnUnhandled()
  348. {
  349. if (ctx != NULL)
  350. {
  351. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("card issue ex unhandled");
  352. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  353. }
  354. }
  355. };
  356. class SAMICCommandEvent : public FSMEvent
  357. {
  358. public:
  359. SAMICCommandEvent() : FSMEvent(USER_EVT_SAM_IC){}
  360. ~SAMICCommandEvent(){}
  361. SpReqAnsContext<CardIssuerStoreService_SAMICCommand_Req, CardIssuerStoreService_SAMICCommand_Ans>::Pointer ctx;
  362. virtual void OnUnhandled()
  363. {
  364. if (ctx != NULL)
  365. {
  366. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("sam/ic unhandled");
  367. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  368. }
  369. }
  370. };
  371. class PrintCardImEvent : public FSMEvent
  372. {
  373. public:
  374. PrintCardImEvent() : FSMEvent(USER_EVT_PRINT_CARD_IM) {}
  375. ~PrintCardImEvent() {}
  376. SpReqAnsContext<CardIssuerStoreService_PrintCardImmediately_Req, CardIssuerStoreService_PrintCardImmediately_Ans>::Pointer ctx;
  377. virtual void OnUnhandled()
  378. {
  379. if (ctx != NULL){
  380. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("PrintCardIm unhandled");
  381. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  382. }
  383. }
  384. };
  385. class PrintCardImFinishedEvent : public FSMEvent
  386. {
  387. public:
  388. PrintCardImFinishedEvent() : FSMEvent(USER_EVT_PRINT_CARD_IM_FINISHED) {}
  389. ~PrintCardImFinishedEvent() {}
  390. SpReqAnsContext<CardIssuerStoreService_PrintCardImmediately_Req, CardIssuerStoreService_PrintCardImmediately_Ans>::Pointer ctx;
  391. virtual void OnUnhandled()
  392. {
  393. if (ctx != NULL)
  394. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  395. }
  396. };
  397. typedef struct EacQueryByEac_X1 {
  398. string xEacNbr;
  399. string xCltNbr;
  400. string xIacNbr;
  401. }EacQueryByEac_X1;
  402. typedef struct CQueryCardTypeReq : CHTTPReq {
  403. struct HEAD {
  404. int xHdrLen;
  405. string xIsuCnl;
  406. string xRtnCod;
  407. }HEAD;
  408. struct BODY {
  409. EacQueryByEac_X1 x1;
  410. }BODY;
  411. int X1Count;
  412. CQueryCardTypeReq() {
  413. X1Count = 1;
  414. }
  415. string ToJson() {
  416. Json::Value allElm,x1Arr;
  417. allElm[REFLECTION(HEAD)][REFLECTION(xHdrLen)] = HEAD.xHdrLen;
  418. allElm[REFLECTION(HEAD)][REFLECTION(xIsuCnl)] = HEAD.xIsuCnl;
  419. allElm[REFLECTION(HEAD)][REFLECTION(xRtnCod)] = HEAD.xRtnCod;
  420. for (int i = 0; i < X1Count; i++) {
  421. Json::Value x1Elm;
  422. Json::FastWriter fwX1Elm;//写入对象
  423. x1Elm[REFLECTION(xEacNbr)] = BODY.x1.xEacNbr.c_str();
  424. x1Elm[REFLECTION(xCltNbr)] = BODY.x1.xCltNbr.c_str();
  425. x1Elm[REFLECTION(xIacNbr)] = BODY.x1.xIacNbr.c_str();
  426. //string x1JsonStr = fwX1Elm.write(x1Elm);
  427. x1Arr[i] = x1Elm;
  428. }
  429. allElm[REFLECTION(BODY)][REFLECTION(EacQueryByEac_X1)] = x1Arr;
  430. Json::FastWriter writer;
  431. string ret = writer.write(allElm);
  432. return ret;
  433. }
  434. } CQueryCardTypeReq;
  435. typedef struct EacQueryByEac_Z1 {
  436. string zEacNbr;
  437. string zEacSts;
  438. string zEacTyp;
  439. string zEacNam;
  440. string zEacNik;
  441. string zEacCod;
  442. string zCltNbr;
  443. string zIacNbr;
  444. string zKeySeq;
  445. string zFndClt;
  446. string zFndIac;
  447. string zFndCpb;
  448. string zFndAtp;
  449. string zFpnClt;
  450. string zFpnIac;
  451. string zCtfCnr;
  452. string zCtfTyp;
  453. string zPsbTag;
  454. string zPsbFac;
  455. string zPsbNbr;
  456. string zPsbCod;
  457. string zPsbSeq;
  458. string zPsbMdm;
  459. string zCvcCod;
  460. string zCvcCd2;
  461. string zCvcIcd;
  462. string zMapBus;
  463. string zMapCnl;
  464. string zMapDpn;
  465. string zMapPwd;
  466. string zMapAut;
  467. string zWrmFlg;
  468. string zBlsFlg;
  469. string zNamFlg;
  470. string zActFlg;
  471. string zSlpFlg;
  472. string zFkcFlg;
  473. string zSnmFlg;
  474. string zWrfAll;
  475. string zWrfNdk;
  476. string zWrfZft;
  477. string zWrfDsk;
  478. string zPayLck;
  479. string zQryTag;
  480. string zFncTag;
  481. string zWdwTag;
  482. string zPayTag;
  483. string zTmpTag;
  484. string zExtTag;
  485. string zCtfTag;
  486. string zMskTag;
  487. string zStfFlg;
  488. string zSlaFlg;
  489. string zBatFlg;
  490. string zAgtFlg;
  491. string zAmgTag;
  492. string zCurTag;
  493. string zImgIdt;
  494. string zGrpFlg;
  495. string zOpnDat;
  496. string zOpnUsr;
  497. string zOpnChk;
  498. string zOpnAut;
  499. string zActDat;
  500. string zClsDat;
  501. string zClsUsr;
  502. string zClsChk;
  503. string zClsAut;
  504. string zDatEft;
  505. string zDatExp;
  506. string zBbkNbr;
  507. string zBrnNbr;
  508. string zBrnMng;
  509. string zCtyCod;
  510. }EacQueryByEac_Z1;
  511. typedef struct CQueryCardTypeRet : CHTTPRet {
  512. struct HEAD {
  513. string xTypCod;
  514. string xHdrLen;
  515. string xSysCod;
  516. string xDskSys;
  517. string xWkeCod;
  518. string xKeyVal;
  519. string xIsuCnl;
  520. string xEncCod;
  521. string xDalCod;
  522. string xCmmTyp;
  523. string xOrgIsu;
  524. string xPreIsu;
  525. string xEntUsr;
  526. string xUsrPwd;
  527. string xIsuDat;
  528. string xIsuTim;
  529. string xMacCod;
  530. string xRtnLvl;
  531. string xRtnCod;
  532. string xDevNbr;
  533. string xTlrNbr;
  534. string xRqsNbr;
  535. string xCmmRsv;
  536. string xDocSiz;
  537. string xItvTms;
  538. string xMsgFlg;
  539. string xAppRsv;
  540. }HEAD;
  541. struct BODY {
  542. EacQueryByEac_Z1 z1;
  543. }BODY;
  544. int Z1Count;
  545. CQueryCardTypeRet() : Z1Count(1) {
  546. }
  547. bool Parse(string strData) {
  548. Json::Value root,tmpZ1;
  549. Json::Reader reader;
  550. Json::Value::UInt index;
  551. if (!reader.parse(strData, root, false))
  552. {
  553. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("reader.parse false");//又不能打印,有什么太大意义?
  554. return false;
  555. }
  556. index = 0;
  557. HEAD.xRtnCod = root["HEAD"][REFLECTION(xRtnCod)].asCString();
  558. if (HEAD.xRtnCod.compare("SUC0000") == 0)
  559. {
  560. tmpZ1 = root["BODY"][REFLECTION(EacQueryByEac_Z1)];
  561. BODY.z1.zPsbMdm = tmpZ1[index][REFLECTION(zPsbMdm)].asCString();
  562. BODY.z1.zEacNbr = tmpZ1[index][REFLECTION(zEacNbr)].asCString();
  563. BODY.z1.zPsbSeq = tmpZ1[index][REFLECTION(zPsbSeq)].asCString();
  564. return true;
  565. }
  566. else
  567. return false;
  568. }
  569. } CQueryCardTypeRet;
  570. typedef struct CRegistSwallowCardReq : CHTTPReq {
  571. string cardNo;
  572. string cardType;
  573. string channel;
  574. string clearInstanceId;
  575. string deviceSciNo;
  576. string bankNo;
  577. string editTime;
  578. string editor;
  579. string fromFlag;
  580. string idKey;
  581. string informType;
  582. string psbCode;
  583. string reasonCode;
  584. string state;
  585. string structId;
  586. string swallowDate;
  587. string swallowTime;
  588. string terminalNo;
  589. string terminalType;
  590. string uuid;
  591. string ToJson() {
  592. Json::Value allElm, x1Arr;
  593. allElm[REFLECTION(cardNo)] = cardNo;
  594. allElm[REFLECTION(deviceSciNo)] = deviceSciNo;
  595. allElm[REFLECTION(reasonCode)] = reasonCode;
  596. allElm[REFLECTION(swallowDate)] = swallowDate;
  597. allElm[REFLECTION(swallowTime)] = swallowTime;
  598. allElm[REFLECTION(terminalNo)] = terminalNo;
  599. allElm[REFLECTION(terminalType)] = terminalType;
  600. Json::FastWriter writer;
  601. string ret = writer.write(allElm);
  602. return ret;
  603. }
  604. } CRegistSwallowCardReq;
  605. typedef struct CRegistSwallowCardRet : CHTTPRet {
  606. struct returnInfo {
  607. string returnCode;
  608. string errorMsg;
  609. }returnInfo;
  610. struct data {
  611. }data;
  612. bool Parse(string strData) {
  613. //DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)(strData.c_str());
  614. Json::Value root, tmpZ1;
  615. Json::Reader reader;
  616. if (!reader.parse(strData, root, false))
  617. {
  618. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("reader.parse false");//又不能打印,有什么太大意义?
  619. return false;
  620. }
  621. if (!root["returnInfo"].isNull()) {
  622. returnInfo.returnCode = root["returnInfo"][REFLECTION(returnCode)].asCString();
  623. return true;
  624. }
  625. else {
  626. return false;//报文结构不对,解析失败
  627. }
  628. //returnInfo.returnCode = root["returnInfo"][REFLECTION(returnCode)].asCString();
  629. }
  630. } CRegistSwallowCardRet;
  631. // 同步卡库计数到后台服务实体类
  632. struct SyncMaterialCountInfo
  633. {
  634. CSimpleStringA strDeviceNo;
  635. unsigned int dwCardBoxNum;
  636. CAutoArray<bool> arrMaintainFlag;
  637. CAutoArray<CSimpleStringA> arrMaintainer;
  638. CAutoArray<unsigned int> arrMaintainTime;
  639. CAutoArray<CSimpleStringA> arrCardBoxNo;
  640. CAutoArray<CSimpleStringA> arrPsbCode;
  641. CAutoArray<CSimpleStringA> arrPsbName;
  642. CAutoArray<unsigned int> arrCardInit;
  643. CAutoArray<unsigned int> arrCardRemains;
  644. CAutoArray<unsigned int> arrCardIssued;
  645. CAutoArray<unsigned int> arrCardMixed;
  646. CAutoArray<unsigned int> arrCardPercent;
  647. };
  648. struct SyncMaterialCountReq1
  649. {
  650. char TerminalNo[16];
  651. char DeviceNo[16];
  652. char Material[16];
  653. DWORD CardBoxNum;
  654. };
  655. struct SyncMaterialCountReq2
  656. {
  657. bool bMaintain;
  658. char Maintainer[16];
  659. DWORD MaintainTime;
  660. char CardBoxNo[20];
  661. char PsbCode[8];
  662. char PsbName[128];
  663. DWORD CardInit;
  664. DWORD CardRemains;
  665. DWORD CardIssued;
  666. DWORD CardMixed;
  667. DWORD CardPercent;
  668. };
  669. struct SyncMaterialCountHTTPReq : CHTTPReq {
  670. SyncMaterialCountHTTPReq() { m_timeOut = 30; }
  671. SyncMaterialCountReq1 reqInfo;
  672. std::vector<SyncMaterialCountReq2> reqData;
  673. virtual string ToJson() {
  674. Json::Value root;
  675. Json::Value arrayObj;
  676. root["terminalNo"] = reqInfo.TerminalNo;
  677. root["deviceNo"] = reqInfo.DeviceNo;
  678. root["materiel"] = reqInfo.Material;
  679. root["cardBoxNum"] = (int)reqInfo.CardBoxNum;
  680. for (int i = 0; i <= reqInfo.CardBoxNum; i++)
  681. {
  682. Json::Value item;
  683. item["CardBoxNo"] = reqData[i].CardBoxNo;
  684. item["PsbCode"] = reqData[i].PsbCode;
  685. item["PsbName"] = reqData[i].PsbName;
  686. item["CardInit"] = (int)reqData[i].CardInit;
  687. item["CardRemains"] = (int)reqData[i].CardRemains;
  688. item["CardIssued"] = (int)reqData[i].CardIssued;
  689. item["CardMixed"] = (int)reqData[i].CardMixed;
  690. item["CardPercent"] = (int)reqData[i].CardPercent;
  691. item["Maintainer"] = reqData[i].Maintainer;
  692. if (reqData[i].MaintainTime == 0)
  693. item["MaintainTime"] = "";
  694. else {
  695. item["MaintainTime"] = CSmallDateTime::GetNow().ToTimeString().GetData();
  696. //DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("MaintainTime:%d", (DWORD)CSmallDateTime::GetNow());
  697. }
  698. item["bMaintain"] = reqData[i].bMaintain;
  699. arrayObj.append(item);
  700. }
  701. root["cardIssueList"] = arrayObj;
  702. return root.toStyledString();
  703. }
  704. };
  705. struct SyncMaterialCountHTTPRet : CHTTPRet {
  706. string m_retStr;
  707. bool Parse(string strData) {
  708. m_retStr = strData;
  709. return true;
  710. }
  711. };
  712. struct JsonElem
  713. {
  714. JsonElem() { type = -1; }
  715. JsonElem(int iVal) {
  716. type = 0;
  717. iValue = iVal;
  718. }
  719. JsonElem(string str) {
  720. type = 1;
  721. strValue = str;
  722. }
  723. int type;//0:int value; 1:string value
  724. int iValue;
  725. string strValue;
  726. };
  727. #pragma region JS接口 event
  728. //JS接口
  729. class EjectJSEvent : public FSMEvent
  730. {
  731. public:
  732. EjectJSEvent() : FSMEvent(USER_EVT_JS_EJECT) {}
  733. ~EjectJSEvent() {}
  734. SpReqAnsContext<CardIssuerStoreService_EjectJS_Req, CardIssuerStoreService_EjectJS_Ans>::Pointer ctx;
  735. virtual void OnUnhandled()
  736. {
  737. if (ctx != NULL)
  738. {
  739. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("EjectJS Operate unhandled");
  740. //ctx->Answer(Error_Unexpect, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  741. }
  742. }
  743. };
  744. class CaptureJSEvent : public FSMEvent
  745. {
  746. public:
  747. CaptureJSEvent() : FSMEvent(USER_EVT_JS_CAPTURE) {}
  748. ~CaptureJSEvent() {}
  749. SpReqAnsContext<CardIssuerStoreService_CaptureJS_Req, CardIssuerStoreService_CaptureJS_Ans>::Pointer ctx;
  750. virtual void OnUnhandled()
  751. {
  752. if (ctx != NULL)
  753. {
  754. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("CaptureJS Operate unhandled");
  755. //ctx->Answer(Error_Unexpect, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  756. }
  757. }
  758. };
  759. class ReadBatchCardInfoInRangeJSEvent : public FSMEvent
  760. {
  761. public:
  762. ReadBatchCardInfoInRangeJSEvent() : FSMEvent(USER_EVT_JS_READ_BATCHCARDINFO_IN_RANGE) {}
  763. ~ReadBatchCardInfoInRangeJSEvent() {}
  764. SpReqAnsContext<CardIssuerStoreService_ReadBatchCardInfoInRangeJS_Req, CardIssuerStoreService_ReadBatchCardInfoInRangeJS_Ans>::Pointer ctx;
  765. virtual void OnUnhandled()
  766. {
  767. if (ctx != NULL)
  768. {
  769. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("ReadBatchCardInfoInRangeJS Operate unhandled");
  770. //ctx->Answer(Error_Unexpect, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  771. }
  772. }
  773. };
  774. class AddAndReadCardFromBoxJSEvent : public FSMEvent
  775. {
  776. public:
  777. AddAndReadCardFromBoxJSEvent() : FSMEvent(USER_EVT_JS_ADD_AND_READ_CRAD_FROMBOX) {}
  778. ~AddAndReadCardFromBoxJSEvent() {}
  779. SpReqAnsContext<CardIssuerStoreService_AddAndReadCardFromBoxJS_Req, CardIssuerStoreService_AddAndReadCardFromBoxJS_Ans>::Pointer ctx;
  780. virtual void OnUnhandled()
  781. {
  782. if (ctx != NULL)
  783. {
  784. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("AddAndReadCardFromBoxJS Operate unhandled");
  785. //ctx->Answer(Error_Unexpect, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  786. }
  787. }
  788. };
  789. class AddCardFromBoxJSEvent : public FSMEvent
  790. {
  791. public:
  792. AddCardFromBoxJSEvent() : FSMEvent(USER_EVT_JS_ADD_CRAD_FROMBOX) {}
  793. ~AddCardFromBoxJSEvent() {}
  794. SpReqAnsContext<CardIssuerStoreService_AddCardFromBoxJS_Req, CardIssuerStoreService_AddCardFromBoxJS_Ans>::Pointer ctx;
  795. virtual void OnUnhandled()
  796. {
  797. if (ctx != NULL)
  798. {
  799. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("AddCardFromBoxJS Operate unhandled");
  800. //ctx->Answer(Error_Unexpect, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  801. }
  802. }
  803. };
  804. class MoveAndReadCardFromSlotJSEvent : public FSMEvent
  805. {
  806. public:
  807. MoveAndReadCardFromSlotJSEvent() : FSMEvent(USER_EVT_JS_MOVE_AND_READ_CARD_FROMSLOT) {}
  808. ~MoveAndReadCardFromSlotJSEvent() {}
  809. SpReqAnsContext<CardIssuerStoreService_MoveAndReadCardFromSlotJS_Req, CardIssuerStoreService_MoveAndReadCardFromSlotJS_Ans>::Pointer ctx;
  810. virtual void OnUnhandled()
  811. {
  812. if (ctx != NULL)
  813. {
  814. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("MoveAndReadCardFromSlotJS Operate unhandled");
  815. //ctx->Answer(Error_Unexpect, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  816. }
  817. }
  818. };
  819. class MoveCardFromSlotJSEvent : public FSMEvent
  820. {
  821. public:
  822. MoveCardFromSlotJSEvent() : FSMEvent(USER_EVT_JS_MOVE_CARD_FROMSLOT) {}
  823. ~MoveCardFromSlotJSEvent() {}
  824. SpReqAnsContext<CardIssuerStoreService_MoveCardFromSlotJS_Req, CardIssuerStoreService_MoveCardFromSlotJS_Ans>::Pointer ctx;
  825. virtual void OnUnhandled()
  826. {
  827. if (ctx != NULL)
  828. {
  829. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("MoveCardFromSlotJS Operate unhandled");
  830. //ctx->Answer(Error_Unexpect, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  831. }
  832. }
  833. };
  834. class MoveBacktoSlotJSEvent : public FSMEvent
  835. {
  836. public:
  837. MoveBacktoSlotJSEvent() : FSMEvent(USER_EVT_JS_MOVEBACK_TO_SLOT) {}
  838. ~MoveBacktoSlotJSEvent() {}
  839. SpReqAnsContext<CardIssuerStoreService_MoveBacktoSlotJS_Req, CardIssuerStoreService_MoveBacktoSlotJS_Ans>::Pointer ctx;
  840. virtual void OnUnhandled()
  841. {
  842. if (ctx != NULL)
  843. {
  844. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("MoveBacktoSlotJS Operate unhandled");
  845. //ctx->Answer(Error_Unexpect, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  846. }
  847. }
  848. };
  849. //class IssueFromSlotJSEvent : public FSMEvent
  850. //{
  851. //public:
  852. // IssueFromSlotJSEvent() : FSMEvent(USER_EVT_JS_ISSUE_FROM_SLOT) {}
  853. // ~IssueFromSlotJSEvent() {}
  854. // SpReqAnsContext<CardIssuerStoreService_IssueFromSlotJS_Req, CardIssuerStoreService_IssueFromSlotJS_Ans>::Pointer ctx;
  855. // virtual void OnUnhandled()
  856. // {
  857. // if (ctx != NULL)
  858. // {
  859. // DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Operate unhandled");
  860. // ctx->Answer(Error_Unexpect, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  861. // }
  862. // }
  863. //};
  864. class ICCommandJSEvent : public FSMEvent
  865. {
  866. public:
  867. ICCommandJSEvent() : FSMEvent(USER_EVT_JS_SAM_IC_COMMAND) {}
  868. ~ICCommandJSEvent() {}
  869. SpReqAnsContext<CardIssuerStoreService_ICCommandJS_Req, CardIssuerStoreService_ICCommandJS_Ans>::Pointer ctx;
  870. virtual void OnUnhandled()
  871. {
  872. if (ctx != NULL)
  873. {
  874. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("ICCommandJS Operate unhandled");
  875. //ctx->Answer(Error_Unexpect, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  876. }
  877. }
  878. };
  879. class WriteTrackJSEvent : public FSMEvent
  880. {
  881. public:
  882. WriteTrackJSEvent() : FSMEvent(USER_EVT_JS_WRITE_TRACK) {}
  883. ~WriteTrackJSEvent() {}
  884. SpReqAnsContext<CardIssuerStoreService_WriteTrackJS_Req, CardIssuerStoreService_WriteTrackJS_Ans>::Pointer ctx;
  885. virtual void OnUnhandled()
  886. {
  887. if (ctx != NULL)
  888. {
  889. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("WriteTrackJS Operate unhandled");
  890. //ctx->Answer(Error_Unexpect, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  891. }
  892. }
  893. };
  894. class PrintCardImmediatelyJSEvent : public FSMEvent
  895. {
  896. public:
  897. PrintCardImmediatelyJSEvent() : FSMEvent(USER_EVT_JS_PRINT_CARD) {}
  898. ~PrintCardImmediatelyJSEvent() {}
  899. SpReqAnsContext<CardIssuerStoreService_PrintCardImmediatelyJS_Req, CardIssuerStoreService_PrintCardImmediatelyJS_Ans>::Pointer ctx;
  900. virtual void OnUnhandled()
  901. {
  902. if (ctx != NULL)
  903. {
  904. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("PrintCardImmediatelyJS Operate unhandled");
  905. //ctx->Answer(Error_Unexpect, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  906. }
  907. }
  908. };
  909. class PostOnlineJSEvent : public FSMEvent
  910. {
  911. public:
  912. PostOnlineJSEvent() : FSMEvent(USER_EVT_JS_POSTONLINE) {}
  913. ~PostOnlineJSEvent() {}
  914. SpReqAnsContext<CardIssuerStoreService_PostOnlineJS_Req, CardIssuerStoreService_PostOnlineJS_Ans>::Pointer ctx;
  915. virtual void OnUnhandled()
  916. {
  917. if (ctx != NULL)
  918. {
  919. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("PostOnlineJS Operate unhandled");
  920. //ctx->Answer(Error_Unexpect, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  921. }
  922. }
  923. };
  924. class IssueFromBoxJSEvent : public FSMEvent
  925. {
  926. public:
  927. IssueFromBoxJSEvent() : FSMEvent(USER_EVT_JS_ISSUE_FROM_BOX) {}
  928. ~IssueFromBoxJSEvent() {}
  929. SpReqAnsContext<CardIssuerStoreService_IssueFromBoxJS_Req, CardIssuerStoreService_IssueFromBoxJS_Ans>::Pointer ctx;
  930. virtual void OnUnhandled()
  931. {
  932. if (ctx != NULL)
  933. {
  934. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("IssueFromBoxJS Operate unhandled");
  935. //ctx->Answer(Error_Unexpect, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  936. }
  937. }
  938. };
  939. class PreOnlineCrossJSEvent : public FSMEvent
  940. {
  941. public:
  942. PreOnlineCrossJSEvent() : FSMEvent(USER_EVT_JS_PREONLINE_CROSS) {}
  943. ~PreOnlineCrossJSEvent() {}
  944. SpReqAnsContext<CardIssuerStoreService_PreOnlineCrossJS_Req, CardIssuerStoreService_PreOnlineCrossJS_Ans>::Pointer ctx;
  945. virtual void OnUnhandled()
  946. {
  947. if (ctx != NULL)
  948. {
  949. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("PreOnlineCrossJS Operate unhandled");
  950. //ctx->Answer(Error_Unexpect, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  951. }
  952. }
  953. };
  954. class QuickSelfcheckFinishEvent : public FSMEvent
  955. {
  956. public:
  957. QuickSelfcheckFinishEvent() : FSMEvent(USER_EVT_QUICK_SELF_CHECK_FINISHED) {}
  958. ~QuickSelfcheckFinishEvent() {}
  959. protected:
  960. private:
  961. };
  962. class ReadJSEvent : public FSMEvent
  963. {
  964. public:
  965. ReadJSEvent() : FSMEvent(USER_EVT_JS_READ) {}
  966. ~ReadJSEvent() {}
  967. SpReqAnsContext<CardIssuerStoreService_ReadJS_Req, CardIssuerStoreService_ReadJS_Ans>::Pointer ctx;
  968. virtual void OnUnhandled()
  969. {
  970. if (ctx != NULL)
  971. {
  972. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA2WCL")("ReadJS Operate unhandled");
  973. //ctx->Answer(Error_Unexpect, CardIssuerStore_UserErrorCode_EntityInStateCannotProcess);
  974. }
  975. }
  976. };
  977. struct AddCardInfo
  978. {
  979. int slot;
  980. string addCardNo;
  981. string addCardSerial;
  982. };
  983. #pragma endregion JS接口 event
  984. class CCardIssuerFSM : public CCommDevFSM<CCardIssuerFSM, CardIssuerClass>
  985. {
  986. public:
  987. enum {s0,s1,s2,s4,s5,s6,s7,s8,s9,s10,s11,s14,s17,s18,s19};
  988. BEGIN_FSM_STATE(CCardIssuerFSM)
  989. FSM_STATE_ENTRY(s0,"Init",s0_on_entry,s0_on_exit,s0_on_event)
  990. FSM_STATE_ENTRY(s1,"Initializing",s1_on_entry,s1_on_exit,s1_on_event)
  991. FSM_STATE_ENTRY(s2,"Idle",s2_on_entry,s2_on_exit,s2_on_event)
  992. FSM_STATE_ENTRY(s4,"Hold",s4_on_entry,s4_on_exit,s4_on_event)
  993. FSM_STATE_ENTRY(s5,"Reading",s5_on_entry,s5_on_exit,s5_on_event)
  994. FSM_STATE_ENTRY(s6,"Ejecting",s6_on_entry,s6_on_exit,s6_on_event)
  995. FSM_STATE_ENTRY(s7,"WaitFetching",s7_on_entry,s7_on_exit,s7_on_event)
  996. FSM_STATE_ENTRY(s8,"Capturing",s8_on_entry,s8_on_exit,s8_on_event)
  997. FSM_STATE_ENTRY(s9,"Failed",s9_on_entry,s9_on_exit,s9_on_event)
  998. FSM_STATE_ENTRY(s10,"Issuing",s10_on_entry,s10_on_exit,s10_on_event)
  999. FSM_STATE_ENTRY(s11,"Writing",s11_on_entry,s11_on_exit,s11_on_event)
  1000. FSM_STATE_ENTRY(s14, "SAMIC", s14_on_entry, s14_on_exit, s14_on_event)
  1001. FSM_STATE_ENTRY(s17, "OperateCardStore", s17_on_entry, s17_on_exit, s17_on_event)
  1002. FSM_STATE_ENTRY(s18, "PrintCardIm", s18_on_entry, s18_on_exit, s18_on_event)
  1003. FSM_STATE_ENTRY(s19, "PreonlineCross", s19_on_entry, s19_on_exit, s19_on_event)
  1004. END_FSM_STATE()
  1005. BEGIN_FSM_RULE(CCardIssuerFSM,s0)
  1006. FSM_RULE_ENTRY(s0, s2, USER_EVT_TEST, 0)
  1007. FSM_RULE_ENTRY(s0,s1,USER_EVT_INIT,0)
  1008. FSM_RULE_ENTRY(s0, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  1009. FSM_RULE_ENTRY(s1,s2,USER_EVT_INITFINISHED,0)
  1010. FSM_RULE_ENTRY(s1,s9,USER_EVT_INITFINISHED,1)
  1011. FSM_RULE_ENTRY(s1, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  1012. FSM_RULE_ENTRY(s2, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  1013. FSM_RULE_ENTRY(s2, s10, USER_EVT_ISSUE_EX, 0)
  1014. FSM_RULE_ENTRY(s2, s17, USER_EVT_QUERYCARDINFO_ON_STORE, 0)
  1015. FSM_RULE_ENTRY(s2, s17, USER_EVT_JS_READ_BATCHCARDINFO_IN_RANGE, 0)//JS 区间盘库
  1016. FSM_RULE_ENTRY(s2, s19, USER_EVT_JS_PREONLINE_CROSS, 0)//JS 跨机激活
  1017. FSM_RULE_ENTRY(s2, s10, USER_EVT_JS_MOVE_AND_READ_CARD_FROMSLOT, 0)//JS 卡槽移卡读卡
  1018. FSM_RULE_ENTRY(s2, s10, USER_EVT_JS_ADD_AND_READ_CRAD_FROMBOX, 0)//JS 加卡箱移卡读卡
  1019. FSM_RULE_ENTRY(s2, s10, USER_EVT_JS_ISSUE_FROM_BOX, 0)//JS 卡箱发卡
  1020. FSM_RULE_ENTRY(s2, s8, USER_EVT_JS_CAPTURE, 0)//JS 吞卡
  1021. FSM_RULE_ENTRY(s2, s10, USER_EVT_JS_MOVE_CARD_FROMSLOT, 0)//JS 卡槽移卡
  1022. FSM_RULE_ENTRY(s2, s10, USER_EVT_JS_ADD_CRAD_FROMBOX, 0)//JS 加卡箱移卡
  1023. FSM_RULE_ENTRY(s4,s5,USER_EVT_READ,0)
  1024. FSM_RULE_ENTRY(s4,s6,USER_EVT_EJECT,0)
  1025. FSM_RULE_ENTRY(s4,s6,USER_EVT_EXIT,0)
  1026. FSM_RULE_ENTRY(s4,s8,USER_EVT_EXIT,1)
  1027. FSM_RULE_ENTRY(s4,s8,USER_EVT_CAPTURE,0)
  1028. FSM_RULE_ENTRY(s4,s11,USER_EVT_WRITE,0)
  1029. FSM_RULE_ENTRY(s4, s14, USER_EVT_SAM_IC, 0)
  1030. FSM_RULE_ENTRY(s4, s18, USER_EVT_PRINT_CARD_IM, 0)
  1031. FSM_RULE_ENTRY(s4, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  1032. FSM_RULE_ENTRY(s4, s2, USER_EVT_ISSUE_EX_FINISHED, 2)
  1033. FSM_RULE_ENTRY(s4, s6, USER_EVT_ISSUE_EX_FINISHED, 6)
  1034. FSM_RULE_ENTRY(s4, s5, USER_EVT_PREONLINE, 0)
  1035. FSM_RULE_ENTRY(s4, s5, USER_EVT_POSTONLINE, 0)
  1036. FSM_RULE_ENTRY(s4, s6, USER_EVT_JS_EJECT, 0)//JS 吐卡
  1037. FSM_RULE_ENTRY(s4, s8, USER_EVT_JS_CAPTURE, 0)//JS 吞卡
  1038. FSM_RULE_ENTRY(s4, s10, USER_EVT_JS_MOVEBACK_TO_SLOT, 0)//JS 移回卡槽
  1039. FSM_RULE_ENTRY(s4, s11, USER_EVT_JS_WRITE_TRACK, 0)//JS 写卡
  1040. FSM_RULE_ENTRY(s4, s14, USER_EVT_JS_SAM_IC_COMMAND, 0)//JS ic交互
  1041. FSM_RULE_ENTRY(s4, s18, USER_EVT_JS_PRINT_CARD, 0)//JS 打印
  1042. FSM_RULE_ENTRY(s4, s5, USER_EVT_JS_POSTONLINE, 0)//JS 联机后处理
  1043. FSM_RULE_ENTRY(s4, s5, USER_EVT_JS_READ, 0)//JS 读卡
  1044. FSM_RULE_ENTRY(s4, s8, EVT_MAINPAGE_DISPLAY, 1)//退到首页事件
  1045. FSM_RULE_ENTRY(s5,s4,USER_EVT_READ_FINISHED,0)
  1046. FSM_RULE_ENTRY(s5,s9,USER_EVT_READ_FINISHED,1)
  1047. FSM_RULE_ENTRY(s5,s4,USER_EVT_READ_FINISHED,2)
  1048. FSM_RULE_ENTRY(s5, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  1049. FSM_RULE_ENTRY(s5, s4, USER_EVT_EXIT, 0)
  1050. FSM_RULE_ENTRY(s5, s4, USER_EVT_PREONLINEFINISHED, 0)
  1051. FSM_RULE_ENTRY(s5, s4, USER_EVT_POSTONLINEFINISHED, 0)
  1052. FSM_RULE_ENTRY_ANY(s5, s4, USER_EVT_JS_POSTONLINE_FINISHED)//JS
  1053. FSM_RULE_ENTRY(s5, s4, USER_EVT_JS_READ_FINISHED, 0)//JS
  1054. FSM_RULE_ENTRY(s5, s2, USER_EVT_JS_READ_FINISHED, 1)//JS 无卡
  1055. FSM_RULE_ENTRY(s6,s7,USER_EVT_EJECTFINISHED,0)
  1056. FSM_RULE_ENTRY(s6,s9,USER_EVT_EJECTFINISHED,1)
  1057. FSM_RULE_ENTRY(s6, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  1058. FSM_RULE_ENTRY(s6, s2, USER_EVT_JS_EJECT_FINISHED, 0)//JS 吐卡且取卡成功,取卡超时吞卡成功
  1059. FSM_RULE_ENTRY(s6, s9, USER_EVT_JS_EJECT_FINISHED, 1)//JS 吐卡失败,取卡超时吞卡失败
  1060. FSM_RULE_ENTRY(s7,s2,USER_EVT_WAITFINISHED,0)
  1061. FSM_RULE_ENTRY(s7,s9,USER_EVT_WAITFINISHED,1)
  1062. FSM_RULE_ENTRY(s7,s8,USER_EVT_WAITFINISHED,2)
  1063. FSM_RULE_ENTRY(s7, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  1064. FSM_RULE_ENTRY(s8,s2,USER_EVT_CAPTUREFINISHED,0)
  1065. FSM_RULE_ENTRY(s8,s9,USER_EVT_CAPTUREFINISHED,1)
  1066. FSM_RULE_ENTRY(s8, s2, USER_EVT_JS_CAPTURE_FINISHED, 0)//JS
  1067. FSM_RULE_ENTRY(s8, s9, USER_EVT_JS_CAPTURE_FINISHED, 1)//JS 吞卡失败
  1068. FSM_RULE_ENTRY(s8, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  1069. FSM_RULE_ENTRY(s9, s2, USER_EVT_RESETFINISHED, 0)
  1070. FSM_RULE_ENTRY(s9, s0, USER_EVT_RESETFINISHED, 2)
  1071. FSM_RULE_ENTRY(s9, FSM_STATE_EXIT, USER_EVT_QUIT, 0)
  1072. FSM_RULE_ENTRY(s10, s6, USER_EVT_ISSUE_EX_FINISHED, 6)
  1073. FSM_RULE_ENTRY(s10, s4, USER_EVT_ISSUE_EX_FINISHED, 0)
  1074. FSM_RULE_ENTRY(s10, s9, USER_EVT_ISSUE_EX_FINISHED, 1)
  1075. FSM_RULE_ENTRY(s10, s2, USER_EVT_ISSUE_EX_FINISHED, 2)
  1076. FSM_RULE_ENTRY(s10, s6, USER_EVT_ISSUE_EX_FINISHED, 6)
  1077. FSM_RULE_ENTRY(s10, s2, USER_EVT_ISSUE_EX_FINISHED, 8)
  1078. FSM_RULE_ENTRY(s10, s2, USER_EVT_EXIT, 0)
  1079. FSM_RULE_ENTRY(s10, s4, USER_EVT_JS_MOVE_AND_READ_CARD_FROMSLOT_FINISHED, 0)//JS
  1080. FSM_RULE_ENTRY(s10, s2, USER_EVT_JS_MOVE_AND_READ_CARD_FROMSLOT_FINISHED, 1)//JS
  1081. FSM_RULE_ENTRY(s10, s4, USER_EVT_JS_ADD_AND_READ_CRAD_FROMBOX_FINISHED, 0)//JS
  1082. FSM_RULE_ENTRY(s10, s2, USER_EVT_JS_ADD_AND_READ_CRAD_FROMBOX_FINISHED, 1)//JS
  1083. FSM_RULE_ENTRY(s10, s4, USER_EVT_JS_MOVE_CARD_FROMSLOT_FINISHED, 0)//JS
  1084. FSM_RULE_ENTRY(s10, s2, USER_EVT_JS_MOVE_CARD_FROMSLOT_FINISHED, 1)//JS
  1085. FSM_RULE_ENTRY(s10, s4, USER_EVT_JS_ADD_CRAD_FROMBOX_FINISHED, 0)//JS
  1086. FSM_RULE_ENTRY(s10, s2, USER_EVT_JS_ADD_CRAD_FROMBOX_FINISHED, 1)//JS
  1087. FSM_RULE_ENTRY(s10, s4, USER_EVT_JS_MOVEBACK_TO_SLOT_FINISHED, 0)//JS
  1088. FSM_RULE_ENTRY(s10, s2, USER_EVT_JS_MOVEBACK_TO_SLOT_FINISHED, 1)//JS
  1089. FSM_RULE_ENTRY(s10, s4, USER_EVT_JS_ISSUE_FROM_BOX_FINISHED, 0)//JS
  1090. FSM_RULE_ENTRY(s10, s2, USER_EVT_JS_ISSUE_FROM_BOX_FINISHED, 1)//JS
  1091. FSM_RULE_ENTRY(s11,s4,USER_EVT_WRITE_FINISHED,0)
  1092. FSM_RULE_ENTRY(s11,s4,USER_EVT_WRITE_FINISHED,1)
  1093. FSM_RULE_ENTRY_ANY(s11, s4, USER_EVT_JS_WRITE_TRACK_FINISHED)//JS
  1094. FSM_RULE_ENTRY(s14, s4, USER_EVT_SAM_IC_FINISHED, 0)
  1095. FSM_RULE_ENTRY_ANY(s14, s4, USER_EVT_JS_SAM_IC_COMMAND_FINISHED)//JS
  1096. FSM_RULE_ENTRY(s17, s2, USER_EVT_QUERYCARDINFO_ON_STORE_FINISHED, 0)
  1097. FSM_RULE_ENTRY(s17, s2, USER_EVT_QUERYCARDINFO_ON_STORE_FINISHED, 2)
  1098. FSM_RULE_ENTRY(s17, s2, USER_EVT_JS_READ_BATCHCARDINFO_IN_RANGE_FINISHED, 0)//JS
  1099. FSM_RULE_ENTRY(s17, s4, USER_EVT_JS_READ_BATCHCARDINFO_IN_RANGE_FINISHED, 1)//JS 读卡,移卡失败
  1100. FSM_RULE_ENTRY(s18, s4, USER_EVT_PRINT_CARD_IM_FINISHED, 0)
  1101. FSM_RULE_ENTRY_ANY(s18, s4, USER_EVT_JS_PRINT_CARD_FINISHED)//JS
  1102. FSM_RULE_ENTRY(s19, s2, USER_EVT_JS_PREONLINE_CROSS_FINISHED, 0)//JS
  1103. FSM_RULE_ENTRY(s19, s9, USER_EVT_JS_PREONLINE_CROSS_FINISHED, 1)//JS 吞卡失败
  1104. END_FSM_RULE()
  1105. CCardIssuerFSM() : m_bCancelAccept(false),m_bWaitingAccept(false),
  1106. m_bWaitAccepteMore(false),m_bExit(false),m_resetTimes(0),m_testResult(Error_Succeed)
  1107. //,m_pTACReject(NULL),m_pIACOnline(NULL),m_pTACOnline(NULL),m_pIACDefault(NULL),m_pTACDefault(NULL)
  1108. ,m_bCDA(false),m_pDataToARQC(NULL),m_bIssuingExit(false)
  1109. ,m_bCardIssued(false),m_issueStatusFromFile(1),m_issueStatus(1),m_currCardNo("")
  1110. , m_captureReason(""), m_machineType(1)
  1111. , m_currentHopper(1), m_hopperNum(1), EncypteDukptHSM(NULL)
  1112. , m_bSettingMaterial(false)
  1113. , m_maxSlot(0), m_addCardNo(""), m_addCardSerial(""), m_hasCardWhileDevOpen(false)
  1114. , m_bChannelOK(false), m_bCancelByRFIC(false), m_devOpenFailedCount(0)
  1115. , m_EacQueryHost(""),m_eacQueryFlag(0), m_bUseCardnoMismatch(false), m_ICRetryTimes(1)
  1116. , m_bCardFromHopper(true), m_bStopUseRF(false),m_rfVendorList(""), m_bUseRFTillNext(false), m_csSwallowCardUrl(""),m_csSyncMaterialUrl(""), m_bNewAnsError(false)
  1117. , m_bCrossPreOnline(false), m_csMagT2Track(""), m_csMagT3Track(""), m_csMagAccout(""), m_csMagRegion(""), m_csMagCardSerial(""), m_csMagCVC(""), m_csMagExpireDate("")
  1118. , m_quickSelfcheck(false), m_SelfcheckSleepTime(0), m_bDoExit(false)
  1119. {
  1120. HARDWARE_ENTITY_RESET_ENTITYID(m_entCode, 0x220);
  1121. cmdDecodeMag2 = NULL;
  1122. cmdDecodeEx = NULL;
  1123. m_aidList.Init(3);
  1124. m_aidList[0] = "A000000333";
  1125. m_aidList[1] = "A0000000108888";
  1126. m_aidList[2] = "A000000790";
  1127. }
  1128. ~CCardIssuerFSM(){}
  1129. virtual ErrorCodeEnum OnInit();
  1130. virtual ErrorCodeEnum OnExit();
  1131. void s0_on_entry();
  1132. void s0_on_exit();
  1133. unsigned int s0_on_event(FSMEvent* event);
  1134. void s1_on_entry();
  1135. void s1_on_exit();
  1136. unsigned int s1_on_event(FSMEvent* event);
  1137. void s2_on_entry();
  1138. void s2_on_exit();
  1139. unsigned int s2_on_event(FSMEvent* event);
  1140. void s4_on_entry();
  1141. void s4_on_exit();
  1142. unsigned int s4_on_event(FSMEvent* event);
  1143. void s5_on_entry();
  1144. void s5_on_exit();
  1145. unsigned int s5_on_event(FSMEvent* event);
  1146. void s6_on_entry();
  1147. void s6_on_exit();
  1148. unsigned int s6_on_event(FSMEvent* event);
  1149. void s7_on_entry();
  1150. void s7_on_exit();
  1151. unsigned int s7_on_event(FSMEvent* event);
  1152. void s8_on_entry();
  1153. void s8_on_exit();
  1154. unsigned int s8_on_event(FSMEvent* event);
  1155. void s9_on_entry();
  1156. void s9_on_exit();
  1157. unsigned int s9_on_event(FSMEvent* event);
  1158. void s10_on_entry();
  1159. void s10_on_exit();
  1160. unsigned int s10_on_event(FSMEvent* event);
  1161. void s11_on_entry();
  1162. void s11_on_exit();
  1163. unsigned int s11_on_event(FSMEvent* event);
  1164. void s14_on_entry();
  1165. void s14_on_exit();
  1166. unsigned int s14_on_event(FSMEvent* event);
  1167. void s17_on_entry();
  1168. void s17_on_exit();
  1169. unsigned int s17_on_event(FSMEvent* event);
  1170. void s18_on_entry();
  1171. void s18_on_exit();
  1172. unsigned int s18_on_event(FSMEvent* event);
  1173. void s19_on_entry();
  1174. void s19_on_exit();
  1175. unsigned int s19_on_event(FSMEvent* event);
  1176. ErrorCodeEnum OpenDevice(BYTE btOpenType, const char *pDevSN);
  1177. int Initial();
  1178. bool GetDevStatus(bool bPrint=true);
  1179. int UnAcceptCard();
  1180. int CaptureCard(SpReqAnsContext<CardIssuerStoreService_Capture_Req,CardIssuerStoreService_Capture_Ans>::Pointer ctx);
  1181. int EjectCard(SpReqAnsContext<CardIssuerStoreService_Eject_Req,CardIssuerStoreService_Eject_Ans>::Pointer ctx);
  1182. int WaitFetchingCard();
  1183. int ReadCard(SpReqAnsContext<CardIssuerStoreService_Read_Req, CardIssuerStoreService_Read_Ans>::Pointer ctx);
  1184. int PreOnline(SpReqAnsContext<CardIssuerStoreService_PreOnline_Req, CardIssuerStoreService_PreOnline_Ans>::Pointer ctx);
  1185. int PostOnline(SpReqAnsContext<CardIssuerStoreService_PostOnline_Req, CardIssuerStoreService_PostOnline_Ans>::Pointer ctx);
  1186. int ReadCard_Contact(SpReqAnsContext<CardIssuerStoreService_Read_Req,CardIssuerStoreService_Read_Ans>::Pointer ctx, bool& bICOK);
  1187. int PreOnline_Contact(SpReqAnsContext<CardIssuerStoreService_PreOnline_Req,CardIssuerStoreService_PreOnline_Ans>::Pointer ctx, bool& bICOK, bool& bContinue);
  1188. int PostOnline_Contact(SpReqAnsContext<CardIssuerStoreService_PostOnline_Req,CardIssuerStoreService_PostOnline_Ans>::Pointer ctx, bool& bICOK);
  1189. int ReadCard_RF(SpReqAnsContext<CardIssuerStoreService_Read_Req, CardIssuerStoreService_Read_Ans>::Pointer ctx);
  1190. int PreOnline_RF(SpReqAnsContext<CardIssuerStoreService_PreOnline_Req, CardIssuerStoreService_PreOnline_Ans>::Pointer ctx);
  1191. int PostOnline_RF(SpReqAnsContext<CardIssuerStoreService_PostOnline_Req, CardIssuerStoreService_PostOnline_Ans>::Pointer ctx);
  1192. int Reset();
  1193. int InternalAcceptCard();
  1194. int AcceptCard(SpReqAnsContext<CardIssuerStoreService_Insert_Req, CardIssuerStoreService_Insert_Ans>::Pointer ctx);
  1195. int IssueCard(SpReqAnsContext<CardIssuerStoreService_IssueEx_Req, CardIssuerStoreService_IssueEx_Ans>::Pointer ctxEx);
  1196. int WriteCard(SpReqAnsContext<CardIssuerStoreService_WriteTrack_Req,CardIssuerStoreService_WriteTrack_Ans>::Pointer ctx);
  1197. void SetExitFlag(bool bFlag=true){m_bExit = bFlag;}
  1198. bool FSMSetIssueFlag(int value=1);
  1199. void FrontSetIssueFlag(bool bValue = true){ FSMSetIssueFlag(bValue); }
  1200. int QueryIssueFlag(){ return m_issueStatus; }
  1201. bool SetCardCaptured(const int num,bool bNewClear=false);
  1202. bool SetCardIssued(const int num,const int hopper);
  1203. bool SetCardRemains(const int num, const int hopper,bool bInit = false);
  1204. bool SetCardMixed(const int num, const int hopper);
  1205. ErrorCodeEnum MachineMoveCardBackNotHold();
  1206. ErrorCodeEnum MachineMoveCardFrontGate(bool bInBussiness=false);
  1207. void SelfTest(EntityTestEnum eTestType,CSmartPointer<ITransactionContext> pTransactionContext);
  1208. DevStateEnum GetDevState() const
  1209. {
  1210. if ((m_eDevState == DEVICE_STATUS_NORMAL)
  1211. && ((m_bHasHopper[0] && m_mixedEx[0] >= 3) || !m_bHasHopper[0])
  1212. && ((m_bHasHopper[1] && m_mixedEx[1] >= 3) || !m_bHasHopper[1])
  1213. && ((m_bHasHopper[2] && m_mixedEx[2] >= 3) || !m_bHasHopper[2]))
  1214. return DEVICE_STATUS_MAINTAINCE;
  1215. else
  1216. return m_eDevState;
  1217. }
  1218. int QueryCardInfo();
  1219. int UpdateLocalRunCfg(CAutoArray<int> hopperArr);
  1220. int SyncDataToDB(bool bMaintain[12],bool bSetCaptured=true);//同步物料计数
  1221. void SetHopperNum(int hopperNum);
  1222. void DoExitWhenIdle();
  1223. int SAMICCommand(SpReqAnsContext<CardIssuerStoreService_SAMICCommand_Req, CardIssuerStoreService_SAMICCommand_Ans>::Pointer ctx);
  1224. bool WriteSlotInfo(CSmartPointer<IConfigInfo> &cfgRun, const char *acc, const char *cardSerial,int slot,bool bClear=false);
  1225. bool ReadSlotInfo(CSmartPointer<IConfigInfo> &cfgRun, CSimpleStringA &acc, CSimpleStringA &cardSerial, int slot, int &hasCard);
  1226. bool WriteCardInfo(CSmartPointer<IConfigInfo> &cfgRun, const char *acc, const char* serial, int slot, bool bClear = false, bool bHasCard = false);
  1227. bool ReadCardInfo(CSmartPointer<IConfigInfo> &cfgRun, CSimpleStringA &acc, CSimpleStringA &serial, int slot);
  1228. int IssueCardFromStore(SpReqAnsContext<CardIssuerStoreService_IssueEx_Req, CardIssuerStoreService_IssueEx_Ans>::Pointer ctx,bool isSpec=false);
  1229. int AddCardToStoreStepFirst(SpReqAnsContext<CardIssuerStoreService_IssueEx_Req, CardIssuerStoreService_IssueEx_Ans>::Pointer ctx);
  1230. int AddCardToStoreStepLast(SpReqAnsContext<CardIssuerStoreService_IssueEx_Req, CardIssuerStoreService_IssueEx_Ans>::Pointer ctx);
  1231. int FindFirstEmptySlot();
  1232. bool IsValidSlotNum(const int slot);
  1233. bool IsSlotHasCard(const int slot);
  1234. bool OperateCardStore(CSmartPointer<IConfigInfo>&spConfigRun, int slot, int& status);
  1235. void ReturnCardInfo(int slotNum, int status, CSmartPointer<IConfigInfo>&spConfigRun, SpReqAnsContext<CardIssuerStoreService_QueryCardInfoOnStore_Req, CardIssuerStoreService_QueryCardInfoOnStore_Ans>::Pointer ctx);
  1236. void ClearLocalRecord(CSmartPointer<IConfigInfo>&spConfigRun);
  1237. bool CheckHasPanKuRecord(CSmartPointer<IConfigInfo>&spConfigRun);
  1238. void AfterPreOnlineOnStore(ErrorCodeEnum eErr,const int slot);
  1239. int QueryCardInfoOnStore(SpReqAnsContext<CardIssuerStoreService_QueryCardInfoOnStore_Req, CardIssuerStoreService_QueryCardInfoOnStore_Ans>::Pointer ctx);
  1240. void GetAddCardInfo(SpReqAnsContext<CardIssuerStoreService_GetAddCardInfo_Req, CardIssuerStoreService_GetAddCardInfo_Ans>::Pointer ctx);
  1241. int PrintCardIm(SpReqAnsContext<CardIssuerStoreService_PrintCardImmediately_Req, CardIssuerStoreService_PrintCardImmediately_Ans>::Pointer ctx);
  1242. void DecodeTracksData(const char *track2, DWORD dwT2size, const char *track3, DWORD dwT3size,char *&magData,bool bT2OK=true,bool bT3OK=true);
  1243. int GetFSMState()
  1244. {
  1245. //DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("m_currentFSMState:%d", m_currentFSMState);
  1246. return m_currentFSMState;
  1247. }
  1248. void GetCardInfo(int &findCard, int &cardPos)
  1249. {
  1250. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("<GetCardInfo>, findCard:%d, cardPos:%d", findCard, cardPos);
  1251. findCard = m_findCard;
  1252. cardPos = m_cardPos;
  1253. }
  1254. int SplitDevModelInfo();
  1255. void SetCancelByRFICFlag(bool bCancel = true) { m_bCancelByRFIC = bCancel; }
  1256. CSimpleStringA GetPreOnlineICCardNo() { return m_currCardNo; }
  1257. void CloseAndClearDevObj(bool bCheckConnecting = true, bool bCloseOnly = false);
  1258. static void HttpsLogCallBack(const char* logtxt);
  1259. //0:unknow(havn't access microservice or access failed),1:both mag & ic ,2:mag only,3:ic only
  1260. int JudgeCardType(CSimpleStringA cardno, bool &bMismatch);
  1261. void QueryCIStatus(SpReqAnsContext<CardIssuerStoreService_QueryCIStatus_Req, CardIssuerStoreService_QueryCIStatus_Ans>::Pointer ctx);
  1262. bool RegistCardWhileCaptureCard(CSimpleStringA cardno);
  1263. bool SyncMaterialCount(IHttpFunc* client,SyncMaterialCountInfo syncInfo);
  1264. bool CheckIsCrossPreOnline() { return m_bCrossPreOnline; }
  1265. void ClearCrossPreOnlineFlag() { m_bCrossPreOnline = false; }
  1266. bool IsInMainPage() {
  1267. if (m_iInWhatPage == PageType_MainPage) {
  1268. return true;
  1269. }
  1270. else {
  1271. return false;
  1272. }
  1273. }
  1274. protected:
  1275. int m_iInsertTries;
  1276. int m_resetTries;
  1277. int m_ejectTries;
  1278. private:
  1279. ///
  1280. int m_resetTimes;
  1281. lpCMBdecodeMag2 cmdDecodeMag2;
  1282. lpCMBdecodeEx cmdDecodeEx;
  1283. bool m_bCancelAccept, m_bWaitingAccept, m_bWaitAccepteMore, m_bExit
  1284. , m_bCDA, m_bIssuingExit, m_bCardIssued, m_bHasHopper[HOPPER_NUM]
  1285. , m_bSettingMaterial, m_hasCardWhileDevOpen, m_bChannelOK, m_bCancelByRFIC
  1286. , m_bCardActiveNotify, m_bCardFromHopper, m_bUseCardnoMismatch, m_bStopUseRF, m_bNewAnsError;
  1287. bool m_bUseRFTillNext;//if ReadCard by RF,the following PreOnline & PostOnline always use RF till the next card(insert/issue)
  1288. bool m_bCrossPreOnline;
  1289. ErrorCodeEnum m_testResult;
  1290. int m_CardCaptured;
  1291. int m_issueStatusFromFile, m_issueStatus/*the status maybe changed by Business call*/;
  1292. //1:default, 2:SCI, 3:no cfg
  1293. int m_machineType;
  1294. int m_currentHopper, m_devOpenFailedCount;
  1295. int m_maxSlot,m_findCard,m_cardPos,m_currentFSMState,m_maxRetainCount, m_eacQueryFlag/*accout query*/
  1296. ,m_ICRetryTimes;
  1297. CSimpleStringA m_CardBoxNoEx[HOPPER_NUM], m_PsbCodeEx[HOPPER_NUM], m_PsbNameEx[HOPPER_NUM], m_MaintainerEx[HOPPER_NUM],m_csMaintainTimeEx[HOPPER_NUM];
  1298. int m_CardInitEx[HOPPER_NUM], m_CardPercentEx[HOPPER_NUM], m_remainsEx[HOPPER_NUM], m_issuedEx[HOPPER_NUM], m_mixedEx[HOPPER_NUM],m_hopperNum;
  1299. DWORD m_MaintainTimeEx[HOPPER_NUM];
  1300. 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];
  1301. CardIssuerStatus m_devStatus;
  1302. CCardProcess *m_pCardProcess;
  1303. CAutoArray<CSimpleStringA> m_aidList;
  1304. pfEncryptDukptHSM EncypteDukptHSM;
  1305. pfGetEncrypedData GetEncrypedData;
  1306. char *m_pDataToARQC;
  1307. long xxTest;
  1308. CSimpleStringA m_currCardNo, m_captureReason, m_csMachineType, m_terminalNo,m_addCardNo,m_addCardSerial, m_rfVendorList, m_csRF;
  1309. char m_AuthCode[2];
  1310. vector<CMBBin> m_vBin;
  1311. UINT64 m_crossStart;
  1312. int m_bBTChecking;
  1313. int SplitTrack2(CSimpleStringA pTrack2,Track2Data &decodeData);
  1314. bool JustReadCardNo();
  1315. bool IsValidCardNo(const char*,int);
  1316. void GetVendorDllName(CSimpleStringA &dllName);
  1317. bool AccountExchange(const char *origAcc, CSimpleStringA &acc,int dir=1);
  1318. bool SetSlotFlag(int slot,bool bReset=false,bool bClear=false);
  1319. void ClearAllLocalSlotInfo();
  1320. bool LoadCMBPrint(CSimpleStringA csBinPath);
  1321. DevCategoryInfo m_devCat;
  1322. bool ToRegistCaptureCardInfo(CSimpleStringA currCardNo="");
  1323. bool IfUseRf();
  1324. CSimpleStringA m_csMagT2Track, m_csMagT3Track, m_csMagAccout, m_csMagRegion, m_csMagCardSerial, m_csMagCVC, m_csMagExpireDate;
  1325. CSimpleStringA m_EacQueryHost, m_csSwallowCardUrl, m_csSyncMaterialUrl;
  1326. MagTracks m_magTracks;
  1327. vector<int> m_badSlot;
  1328. std::map<std::string, JsonElem> m_mapJsonErr;
  1329. //oilyang@20230504 尝试对厂商api返回的eErr做映射转换,如果在列表则用转换值,如果不再则保持原有厂商api转换逻辑
  1330. DWORD TryMapAPIRetToUEC(ErrorCodeEnum eErr, DWORD dwApiCode, bool &bTrans)
  1331. {
  1332. bTrans = true;
  1333. switch (eErr)
  1334. {
  1335. case Error_Dev_HopperHasNoCard:
  1336. return CardIssuerStore_UserErrorCode_Dev_HopperHasNoCard;
  1337. case Error_Dev_HopperMissing:
  1338. return CardIssuerStore_UserErrorCode_Dev_HopperMissing;
  1339. case Error_Dev_TransCarJammed:
  1340. return CardIssuerStore_UserErrorCode_Dev_TransCarJammed;
  1341. case Error_Dev_RetainBinFull:
  1342. return CardIssuerStore_UserErrorCode_Dev_RetainBinFull;
  1343. case Error_Dev_RetainBinMissing:
  1344. return CardIssuerStore_UserErrorCode_Dev_RetainBinMissing;
  1345. case Error_Dev_CardInReader:
  1346. return CardIssuerStore_UserErrorCode_Dev_CardInReader;
  1347. case Error_Dev_SlotHasNoCard:
  1348. return CardIssuerStore_UserErrorCode_Dev_SlotHasNoCard;
  1349. case Error_Dev_CardInSlot:
  1350. return CardIssuerStore_UserErrorCode_Dev_CardInSlot;
  1351. case Error_Dev_NoCardInReader:
  1352. return CardIssuerStore_UserErrorCode_Dev_NoCardInReader;
  1353. case Error_Dev_CardJammed:
  1354. return CardIssuerStore_UserErrorCode_Dev_CardJammed;
  1355. case Error_Dev_SlotJammed:
  1356. return CardIssuerStore_UserErrorCode_Dev_SlotJammed;
  1357. case Error_Dev_SlotInvalid:
  1358. return CardIssuerStore_UserErrorCode_Dev_SlotInvalid;
  1359. default:
  1360. bTrans = false;
  1361. return dwApiCode;
  1362. }
  1363. }
  1364. CSimpleStringA generateJsonString(std::map<std::string, JsonElem>& objectArr);
  1365. bool IsInBusiness() const
  1366. {
  1367. return (m_bCrossPreOnline || m_iInWhatPage == PageType_Other);
  1368. }
  1369. void GetCardProcessLastErr(ErrorCodeEnum& eErrCode, CSimpleStringA& lastApiName,CSimpleStringA& alarmMsg,CSimpleStringA& csErrMsgWithReturnCode);
  1370. #pragma region JS接口具体实现方法
  1371. public:
  1372. int EjectJS(SpReqAnsContext<CardIssuerStoreService_EjectJS_Req, CardIssuerStoreService_EjectJS_Ans>::Pointer ctx);
  1373. int CaptureJS(SpReqAnsContext<CardIssuerStoreService_CaptureJS_Req, CardIssuerStoreService_CaptureJS_Ans>::Pointer ctx);
  1374. int ReadBatchCardInfoInRangeJS(SpReqAnsContext<CardIssuerStoreService_ReadBatchCardInfoInRangeJS_Req, CardIssuerStoreService_ReadBatchCardInfoInRangeJS_Ans>::Pointer ctx);
  1375. int GetCardInStoreJS(SpReqAnsContext<CardIssuerStoreService_GetCardInStoreJS_Req, CardIssuerStoreService_GetCardInStoreJS_Ans>::Pointer ctx);
  1376. int AddAndReadCardFromBoxJS(SpReqAnsContext<CardIssuerStoreService_AddAndReadCardFromBoxJS_Req, CardIssuerStoreService_AddAndReadCardFromBoxJS_Ans>::Pointer ctx);
  1377. int AddCardFromBoxJS(SpReqAnsContext<CardIssuerStoreService_AddCardFromBoxJS_Req, CardIssuerStoreService_AddCardFromBoxJS_Ans>::Pointer ctx);
  1378. int MoveAndReadCardFromSlotJS(SpReqAnsContext<CardIssuerStoreService_MoveAndReadCardFromSlotJS_Req, CardIssuerStoreService_MoveAndReadCardFromSlotJS_Ans>::Pointer ctx);
  1379. int MoveCardFromSlotJS(SpReqAnsContext<CardIssuerStoreService_MoveCardFromSlotJS_Req, CardIssuerStoreService_MoveCardFromSlotJS_Ans>::Pointer ctx);
  1380. int MoveBacktoSlotJS(SpReqAnsContext<CardIssuerStoreService_MoveBacktoSlotJS_Req, CardIssuerStoreService_MoveBacktoSlotJS_Ans>::Pointer ctx);
  1381. bool OperateNewCardStore(int slot, CSimpleStringA& addCardNo, CSimpleStringA& addCardSerial, int& status);
  1382. //int IssueFromSlotJS(SpReqAnsContext<CardIssuerStoreService_IssueFromSlotJS_Req, CardIssuerStoreService_IssueFromSlotJS_Ans>::Pointer ctx);
  1383. //void QueryInternalHasCardJS(SpReqAnsContext<CardIssuerStoreService_QueryInternalHasCardJS_Req, CardIssuerStoreService_QueryInternalHasCardJS_Ans>::Pointer ctx);
  1384. void QueryHasCardJS(SpReqAnsContext<CardIssuerStoreService_QueryHasCardJS_Req, CardIssuerStoreService_QueryHasCardJS_Ans>::Pointer ctx);
  1385. int WriteTrackJS(SpReqAnsContext<CardIssuerStoreService_WriteTrackJS_Req, CardIssuerStoreService_WriteTrackJS_Ans>::Pointer ctx);
  1386. int PrintCardImmediatelyJS(SpReqAnsContext<CardIssuerStoreService_PrintCardImmediatelyJS_Req, CardIssuerStoreService_PrintCardImmediatelyJS_Ans>::Pointer ctx);
  1387. //int SAMICCommandJS(SpReqAnsContext<CardIssuerStoreService_SAMICCommandJS_Req, CardIssuerStoreService_SAMICCommandJS_Ans>::Pointer ctx);
  1388. int ICCommandJS(SpReqAnsContext<CardIssuerStoreService_ICCommandJS_Req, CardIssuerStoreService_ICCommandJS_Ans>::Pointer ctx);
  1389. int PostOnlineJS(SpReqAnsContext<CardIssuerStoreService_PostOnlineJS_Req, CardIssuerStoreService_PostOnlineJS_Ans>::Pointer ctx);
  1390. int IssueFromBoxJS(SpReqAnsContext<CardIssuerStoreService_IssueFromBoxJS_Req, CardIssuerStoreService_IssueFromBoxJS_Ans>::Pointer ctx);
  1391. int PreOnlineCrossJS(SpReqAnsContext<CardIssuerStoreService_PreOnlineCrossJS_Req, CardIssuerStoreService_PreOnlineCrossJS_Ans>::Pointer ctx);
  1392. int ReadJS(SpReqAnsContext<CardIssuerStoreService_ReadJS_Req, CardIssuerStoreService_ReadJS_Ans>::Pointer ctx);
  1393. #pragma endregion JS接口具体实现方法
  1394. #pragma region JS新增接口
  1395. DWORD GetFsmStateErrCode();
  1396. CSimpleStringA MaskCardno(const char* cardno);
  1397. int PostOnlineJS_Contact(SpReqAnsContext<CardIssuerStoreService_PostOnlineJS_Req, CardIssuerStoreService_PostOnlineJS_Ans>::Pointer ctx, bool& bICOK);
  1398. int PostOnlineJS_RF(SpReqAnsContext<CardIssuerStoreService_PostOnlineJS_Req, CardIssuerStoreService_PostOnlineJS_Ans>::Pointer ctx);
  1399. int ReadMag(SpReqAnsContext<CardIssuerStoreService_ReadJS_Req, CardIssuerStoreService_ReadJS_Ans>::Pointer ctx,bool& bReadCardInfo,bool& bReadMag,CSimpleStringA& t2Account);
  1400. int CheckCardType(CSimpleStringA cardNo,bool bReadMag, int& ICtype);
  1401. int PreOnlineJS_Contact(SpReqAnsContext<CardIssuerStoreService_ReadJS_Req, CardIssuerStoreService_ReadJS_Ans>::Pointer ctx, bool& bICOK, bool& bContinue);
  1402. int PreOnlineJS_RF(SpReqAnsContext<CardIssuerStoreService_ReadJS_Req, CardIssuerStoreService_ReadJS_Ans>::Pointer ctx);
  1403. bool AfterPreOnlineCrossJS(const int slot, CSimpleStringA cardNo);
  1404. int PreOnlineCrossJS_Contact(SpReqAnsContext<CardIssuerStoreService_PreOnlineCrossJS_Req, CardIssuerStoreService_PreOnlineCrossJS_Ans>::Pointer ctx, bool& bICOK, bool& bContinue, bool& CaptureResult);
  1405. int PreOnlineCrossJS_RF(SpReqAnsContext<CardIssuerStoreService_PreOnlineCrossJS_Req, CardIssuerStoreService_PreOnlineCrossJS_Ans>::Pointer ctx, bool& CaptureResult);
  1406. int QuickSelfCheckImpl();
  1407. void setQuickSelfCheck() {
  1408. m_quickSelfcheck = true;
  1409. }
  1410. bool SetCardCapturedJS(const int num, bool bNewClear = false);
  1411. void SetDoExitFlag(bool bFlag) { m_bDoExit = bFlag; }
  1412. virtual void OnStateTrans(int iSrcState, int iDstState);
  1413. CSimpleStringA getRTACode(DWORD dwUserCode) {
  1414. CSimpleStringA rtaMsg = this->GetEntityBase()->GetFunction()->UserCodeToRTACode(dwUserCode);
  1415. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("rtaMsg=%s", rtaMsg.GetData());
  1416. return rtaMsg;
  1417. }
  1418. #pragma endregion JS新增接口
  1419. #pragma region JS新增字段
  1420. private:
  1421. bool m_quickSelfcheck;
  1422. bool m_bDoExit;
  1423. public:
  1424. int m_SelfcheckSleepTime;
  1425. #pragma endregion JS新增字段
  1426. };
  1427. struct InitTask : public ITaskSp
  1428. {
  1429. CCardIssuerFSM* fsm;
  1430. InitTask(CCardIssuerFSM* f) : fsm(f) {}
  1431. void Process()
  1432. {
  1433. FSMEvent *e = new FSMEvent(USER_EVT_INITFINISHED);
  1434. e->param1 = fsm->Initial();
  1435. fsm->PostEventFIFO(e);
  1436. }
  1437. };
  1438. struct IssueTask : public ITaskSp
  1439. {
  1440. CCardIssuerFSM* fsm;
  1441. SpReqAnsContext<CardIssuerStoreService_IssueEx_Req, CardIssuerStoreService_IssueEx_Ans>::Pointer ctxEx;
  1442. IssueTask(CCardIssuerFSM* f) : fsm(f) {}
  1443. void Process()
  1444. {
  1445. LOG_FUNCTION();
  1446. FSMEvent* e;
  1447. if (ctxEx != NULL)
  1448. e = new FSMEvent(USER_EVT_ISSUE_EX_FINISHED);
  1449. else
  1450. {
  1451. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("IssueTask:ctx is null");
  1452. return;
  1453. }
  1454. e->param1 = fsm->IssueCard(ctxEx);
  1455. fsm->PostEventFIFO(e);
  1456. }
  1457. };
  1458. struct QueryCardInfoOnStoreTask : public ITaskSp
  1459. {
  1460. CCardIssuerFSM* fsm;
  1461. SpReqAnsContext<CardIssuerStoreService_QueryCardInfoOnStore_Req, CardIssuerStoreService_QueryCardInfoOnStore_Ans>::Pointer ctx;
  1462. QueryCardInfoOnStoreTask(CCardIssuerFSM* f) : fsm(f){}
  1463. void Process()
  1464. {
  1465. LOG_FUNCTION();
  1466. FSMEvent* e;
  1467. if(ctx != NULL)
  1468. e = new FSMEvent(USER_EVT_QUERYCARDINFO_ON_STORE_FINISHED);
  1469. else
  1470. {
  1471. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("QueryCardInfoOnStoreTask: ctx is null");
  1472. return;
  1473. }
  1474. e->param1 = fsm->QueryCardInfoOnStore(ctx);
  1475. fsm->PostEventFIFO(e);
  1476. }
  1477. };
  1478. struct ReadTask : public ITaskSp
  1479. {
  1480. SpReqAnsContext<CardIssuerStoreService_Read_Req,CardIssuerStoreService_Read_Ans>::Pointer ctx;
  1481. CCardIssuerFSM* fsm;
  1482. ReadTask(CCardIssuerFSM* f) : fsm(f) {}
  1483. void Process()
  1484. {
  1485. CardReadFinishedEvent *e = new CardReadFinishedEvent();
  1486. e->ctx = ctx;
  1487. e->param1 = fsm->ReadCard(ctx);
  1488. fsm->PostEventFIFO(e);
  1489. }
  1490. };
  1491. struct PreOnlineTask : public ITaskSp
  1492. {
  1493. SpReqAnsContext<CardIssuerStoreService_PreOnline_Req,CardIssuerStoreService_PreOnline_Ans>::Pointer ctx;
  1494. CCardIssuerFSM* fsm;
  1495. PreOnlineTask(CCardIssuerFSM* f) : fsm(f) {}
  1496. void Process()
  1497. {
  1498. FSMEvent *e = new FSMEvent(USER_EVT_PREONLINEFINISHED);
  1499. e->param1 = fsm->PreOnline(ctx);//oilyang@20220611 实际上,为简化处理,PreOnline函数默认返回0
  1500. fsm->ClearCrossPreOnlineFlag();//清除联机状态
  1501. fsm->PostEventFIFO(e);
  1502. }
  1503. };
  1504. struct PostOnlineTask : public ITaskSp
  1505. {
  1506. SpReqAnsContext<CardIssuerStoreService_PostOnline_Req,CardIssuerStoreService_PostOnline_Ans>::Pointer ctx;
  1507. CCardIssuerFSM* fsm;
  1508. PostOnlineTask(CCardIssuerFSM* f) : fsm(f) {}
  1509. void Process()
  1510. {
  1511. FSMEvent *e = new FSMEvent(USER_EVT_POSTONLINEFINISHED);
  1512. e->param1 = fsm->PostOnline(ctx);
  1513. fsm->PostEventFIFO(e);
  1514. }
  1515. };
  1516. struct CaptureTask : public ITaskSp
  1517. {
  1518. CCardIssuerFSM* fsm;
  1519. SpReqAnsContext<CardIssuerStoreService_Capture_Req,CardIssuerStoreService_Capture_Ans>::Pointer ctx;
  1520. CaptureTask(CCardIssuerFSM* f) : fsm(f) {}
  1521. void Process()
  1522. {
  1523. FSMEvent *e = new FSMEvent(USER_EVT_CAPTUREFINISHED);
  1524. e->param1 = fsm->CaptureCard(ctx);
  1525. fsm->PostEventFIFO(e);
  1526. }
  1527. };
  1528. struct EjectTask : public ITaskSp
  1529. {
  1530. SpReqAnsContext<CardIssuerStoreService_Eject_Req,CardIssuerStoreService_Eject_Ans>::Pointer ctx;
  1531. CCardIssuerFSM* fsm;
  1532. EjectTask(CCardIssuerFSM* f) : fsm(f) {}
  1533. void Process()
  1534. {
  1535. FSMEvent *e = new FSMEvent(USER_EVT_EJECTFINISHED);
  1536. e->param1 = fsm->EjectCard(ctx);
  1537. fsm->PostEventFIFO(e);
  1538. }
  1539. };
  1540. struct WaitFetchingTask : public ITaskSp
  1541. {
  1542. CCardIssuerFSM* fsm;
  1543. WaitFetchingTask(CCardIssuerFSM* f) : fsm(f) {}
  1544. void Process()
  1545. {
  1546. FSMEvent *e = new FSMEvent(USER_EVT_WAITFINISHED);
  1547. e->param1 = fsm->WaitFetchingCard();
  1548. fsm->PostEventFIFO(e);
  1549. }
  1550. };
  1551. struct ResetTask : public ITaskSp
  1552. {
  1553. CCardIssuerFSM* fsm;
  1554. ResetTask(CCardIssuerFSM* f) : fsm(f) {}
  1555. void Process()
  1556. {
  1557. ResetFinishedEvent *e = new ResetFinishedEvent();
  1558. e->param1 = fsm->Reset();
  1559. fsm->PostEventFIFO(e);
  1560. }
  1561. };
  1562. struct WriteTask : public ITaskSp
  1563. {
  1564. SpReqAnsContext<CardIssuerStoreService_WriteTrack_Req,CardIssuerStoreService_WriteTrack_Ans>::Pointer ctx;
  1565. CCardIssuerFSM* fsm;
  1566. WriteTask(CCardIssuerFSM* f) : fsm(f) {}
  1567. void Process()
  1568. {
  1569. CardWriteFinishedEvent *e = new CardWriteFinishedEvent();
  1570. e->ctx = ctx;
  1571. e->param1 = fsm->WriteCard(ctx);
  1572. fsm->PostEventFIFO(e);
  1573. }
  1574. };
  1575. struct DoExitWhenIdleTask : public ITaskSp
  1576. {
  1577. CCardIssuerFSM* fsm;
  1578. DoExitWhenIdleTask(CCardIssuerFSM* f) : fsm(f) {}
  1579. void Process()
  1580. {
  1581. fsm->DoExitWhenIdle();
  1582. fsm->SetDoExitFlag(false);
  1583. }
  1584. };
  1585. struct SAMICCommandTask : public ITaskSp
  1586. {
  1587. CCardIssuerFSM* fsm;
  1588. SpReqAnsContext<CardIssuerStoreService_SAMICCommand_Req, CardIssuerStoreService_SAMICCommand_Ans>::Pointer ctx;
  1589. SAMICCommandTask(CCardIssuerFSM* f) : fsm(f) {}
  1590. void Process()
  1591. {
  1592. FSMEvent* e = new FSMEvent(USER_EVT_SAM_IC_FINISHED);
  1593. e->param1 = fsm->SAMICCommand(ctx);
  1594. fsm->PostEventFIFO(e);
  1595. }
  1596. };
  1597. struct PrintCardImTask : public ITaskSp
  1598. {
  1599. CCardIssuerFSM* fsm;
  1600. SpReqAnsContext<CardIssuerStoreService_PrintCardImmediately_Req, CardIssuerStoreService_PrintCardImmediately_Ans>::Pointer ctx;
  1601. PrintCardImTask(CCardIssuerFSM* f) : fsm(f) {}
  1602. void Process()
  1603. {
  1604. FSMEvent* e = new FSMEvent(USER_EVT_PRINT_CARD_IM_FINISHED);
  1605. e->param1 = fsm->PrintCardIm(ctx);
  1606. fsm->PostEventFIFO(e);
  1607. }
  1608. };
  1609. struct RegistCaptureCardInfoTask : public ITaskSp
  1610. {
  1611. CCardIssuerFSM* fsm;
  1612. CSimpleStringA cardno;
  1613. RegistCaptureCardInfoTask(CCardIssuerFSM* f, CSimpleStringA cardno) : fsm(f),cardno(cardno) {}
  1614. void Process()
  1615. {
  1616. fsm->RegistCardWhileCaptureCard(cardno);
  1617. }
  1618. };
  1619. struct SyncMaterialCountTask : public ITaskSp
  1620. {
  1621. CCardIssuerFSM* fsm;
  1622. SyncMaterialCountInfo syncInfo;
  1623. SyncMaterialCountTask(CCardIssuerFSM* f, SyncMaterialCountInfo syncMaterialInfo){
  1624. fsm = f;
  1625. syncInfo = syncMaterialInfo;
  1626. }
  1627. void Process()
  1628. {
  1629. LOG_FUNCTION();
  1630. //同步物料信息
  1631. IHttpFunc* client;
  1632. client = create_http(fsm->HttpsLogCallBack);
  1633. bool ret = fsm->SyncMaterialCount(client,syncInfo);
  1634. client->Destory();
  1635. }
  1636. };
  1637. #pragma region JS接口 工作线程
  1638. //吐卡
  1639. struct EjectJSTask : public ITaskSp
  1640. {
  1641. CCardIssuerFSM* fsm;
  1642. SpReqAnsContext<CardIssuerStoreService_EjectJS_Req, CardIssuerStoreService_EjectJS_Ans>::Pointer ctx;
  1643. EjectJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1644. void Process()
  1645. {
  1646. FSMEvent* e = new FSMEvent(USER_EVT_JS_EJECT_FINISHED);
  1647. e->param1 = fsm->EjectJS(ctx);
  1648. fsm->PostEventFIFO(e);
  1649. }
  1650. };
  1651. //吞卡
  1652. struct CaptureJSTask : public ITaskSp
  1653. {
  1654. CCardIssuerFSM* fsm;
  1655. SpReqAnsContext<CardIssuerStoreService_CaptureJS_Req, CardIssuerStoreService_CaptureJS_Ans>::Pointer ctx;
  1656. CaptureJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1657. void Process()
  1658. {
  1659. FSMEvent* e = new FSMEvent(USER_EVT_JS_CAPTURE_FINISHED);
  1660. e->param1 = fsm->CaptureJS(ctx);
  1661. fsm->PostEventFIFO(e);
  1662. }
  1663. };
  1664. //盘库
  1665. struct ReadBatchCardInfoInRangeJSTask : public ITaskSp
  1666. {
  1667. CCardIssuerFSM* fsm;
  1668. SpReqAnsContext<CardIssuerStoreService_ReadBatchCardInfoInRangeJS_Req, CardIssuerStoreService_ReadBatchCardInfoInRangeJS_Ans>::Pointer ctx;
  1669. ReadBatchCardInfoInRangeJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1670. void Process()
  1671. {
  1672. FSMEvent* e = new FSMEvent(USER_EVT_JS_READ_BATCHCARDINFO_IN_RANGE_FINISHED);
  1673. e->param1 = fsm->ReadBatchCardInfoInRangeJS(ctx);
  1674. fsm->PostEventFIFO(e);
  1675. }
  1676. };
  1677. //加卡读卡
  1678. struct AddAndReadCardFromBoxJSTask : public ITaskSp
  1679. {
  1680. CCardIssuerFSM* fsm;
  1681. SpReqAnsContext<CardIssuerStoreService_AddAndReadCardFromBoxJS_Req, CardIssuerStoreService_AddAndReadCardFromBoxJS_Ans>::Pointer ctx;
  1682. AddAndReadCardFromBoxJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1683. void Process()
  1684. {
  1685. FSMEvent* e = new FSMEvent(USER_EVT_JS_ADD_AND_READ_CRAD_FROMBOX_FINISHED);
  1686. e->param1 = fsm->AddAndReadCardFromBoxJS(ctx);
  1687. fsm->PostEventFIFO(e);
  1688. }
  1689. };
  1690. //加卡箱移卡
  1691. struct AddCardFromBoxJSTask : public ITaskSp
  1692. {
  1693. CCardIssuerFSM* fsm;
  1694. SpReqAnsContext<CardIssuerStoreService_AddCardFromBoxJS_Req, CardIssuerStoreService_AddCardFromBoxJS_Ans>::Pointer ctx;
  1695. AddCardFromBoxJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1696. void Process()
  1697. {
  1698. FSMEvent* e = new FSMEvent(USER_EVT_JS_ADD_CRAD_FROMBOX_FINISHED);
  1699. e->param1 = fsm->AddCardFromBoxJS(ctx);
  1700. fsm->PostEventFIFO(e);
  1701. }
  1702. };
  1703. //卡槽移卡读卡
  1704. struct MoveAndReadCardFromSlotJSTask : public ITaskSp
  1705. {
  1706. CCardIssuerFSM* fsm;
  1707. SpReqAnsContext<CardIssuerStoreService_MoveAndReadCardFromSlotJS_Req, CardIssuerStoreService_MoveAndReadCardFromSlotJS_Ans>::Pointer ctx;
  1708. MoveAndReadCardFromSlotJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1709. void Process()
  1710. {
  1711. FSMEvent* e = new FSMEvent(USER_EVT_JS_MOVE_AND_READ_CARD_FROMSLOT_FINISHED);
  1712. e->param1 = fsm->MoveAndReadCardFromSlotJS(ctx);
  1713. fsm->PostEventFIFO(e);
  1714. }
  1715. };
  1716. //卡槽移卡
  1717. struct MoveCardFromSlotJSTask : public ITaskSp
  1718. {
  1719. CCardIssuerFSM* fsm;
  1720. SpReqAnsContext<CardIssuerStoreService_MoveCardFromSlotJS_Req, CardIssuerStoreService_MoveCardFromSlotJS_Ans>::Pointer ctx;
  1721. MoveCardFromSlotJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1722. void Process()
  1723. {
  1724. FSMEvent* e = new FSMEvent(USER_EVT_JS_MOVE_CARD_FROMSLOT_FINISHED);
  1725. e->param1 = fsm->MoveCardFromSlotJS(ctx);
  1726. fsm->PostEventFIFO(e);
  1727. }
  1728. };
  1729. //移回卡槽
  1730. struct MoveBacktoSlotJSTask : public ITaskSp
  1731. {
  1732. CCardIssuerFSM* fsm;
  1733. SpReqAnsContext<CardIssuerStoreService_MoveBacktoSlotJS_Req, CardIssuerStoreService_MoveBacktoSlotJS_Ans>::Pointer ctx;
  1734. MoveBacktoSlotJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1735. void Process()
  1736. {
  1737. FSMEvent* e = new FSMEvent(USER_EVT_JS_MOVEBACK_TO_SLOT_FINISHED);
  1738. e->param1 = fsm->MoveBacktoSlotJS(ctx);
  1739. fsm->PostEventFIFO(e);
  1740. }
  1741. };
  1742. //卡库领卡
  1743. //struct IssueFromSlotJSTask : public ITaskSp
  1744. //{
  1745. // CCardIssuerFSM* fsm;
  1746. // SpReqAnsContext<CardIssuerStoreService_IssueFromSlotJS_Req, CardIssuerStoreService_IssueFromSlotJS_Ans>::Pointer ctx;
  1747. // IssueFromSlotJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1748. // void Process()
  1749. // {
  1750. // FSMEvent* e = new FSMEvent(USER_EVT_JS_ISSUE_FROM_SLOT_FINISHED);
  1751. // e->param1 = fsm->IssueFromSlotJS(ctx);
  1752. // fsm->PostEventFIFO(e);
  1753. // }
  1754. //};
  1755. //写卡
  1756. struct WriteTrackJSTask : public ITaskSp
  1757. {
  1758. CCardIssuerFSM* fsm;
  1759. SpReqAnsContext<CardIssuerStoreService_WriteTrackJS_Req, CardIssuerStoreService_WriteTrackJS_Ans>::Pointer ctx;
  1760. WriteTrackJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1761. void Process()
  1762. {
  1763. FSMEvent* e = new FSMEvent(USER_EVT_JS_WRITE_TRACK_FINISHED);
  1764. e->param1 = fsm->WriteTrackJS(ctx);
  1765. fsm->PostEventFIFO(e);
  1766. }
  1767. };
  1768. //打印
  1769. struct PrintCardImmediatelyJSTask : public ITaskSp
  1770. {
  1771. CCardIssuerFSM* fsm;
  1772. SpReqAnsContext<CardIssuerStoreService_PrintCardImmediatelyJS_Req, CardIssuerStoreService_PrintCardImmediatelyJS_Ans>::Pointer ctx;
  1773. PrintCardImmediatelyJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1774. void Process()
  1775. {
  1776. FSMEvent* e = new FSMEvent(USER_EVT_JS_WRITE_TRACK_FINISHED);
  1777. e->param1 = fsm->PrintCardImmediatelyJS(ctx);
  1778. fsm->PostEventFIFO(e);
  1779. }
  1780. };
  1781. //IC交互
  1782. //struct SAMICCommandJSTask : public ITaskSp
  1783. //{
  1784. // CCardIssuerFSM* fsm;
  1785. // SpReqAnsContext<CardIssuerStoreService_SAMICCommandJS_Req, CardIssuerStoreService_SAMICCommandJS_Ans>::Pointer ctx;
  1786. // SAMICCommandJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1787. // void Process()
  1788. // {
  1789. // FSMEvent* e = new FSMEvent(USER_EVT_JS_WRITE_TRACK_FINISHED);
  1790. // e->param1 = fsm->SAMICCommandJS(ctx);
  1791. // fsm->PostEventFIFO(e);
  1792. // }
  1793. //};
  1794. //IC交互
  1795. struct ICCommandJSTask : public ITaskSp
  1796. {
  1797. CCardIssuerFSM* fsm;
  1798. SpReqAnsContext<CardIssuerStoreService_ICCommandJS_Req, CardIssuerStoreService_ICCommandJS_Ans>::Pointer ctx;
  1799. ICCommandJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1800. void Process()
  1801. {
  1802. FSMEvent* e = new FSMEvent(USER_EVT_JS_SAM_IC_COMMAND_FINISHED);
  1803. e->param1 = fsm->ICCommandJS(ctx);
  1804. fsm->PostEventFIFO(e);
  1805. }
  1806. };
  1807. //联机后处理
  1808. struct PostOnlineJSTask : public ITaskSp
  1809. {
  1810. CCardIssuerFSM* fsm;
  1811. SpReqAnsContext<CardIssuerStoreService_PostOnlineJS_Req, CardIssuerStoreService_PostOnlineJS_Ans>::Pointer ctx;
  1812. PostOnlineJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1813. void Process()
  1814. {
  1815. FSMEvent* e = new FSMEvent(USER_EVT_JS_POSTONLINE_FINISHED);
  1816. e->param1 = fsm->PostOnlineJS(ctx);
  1817. fsm->PostEventFIFO(e);
  1818. }
  1819. };
  1820. //卡箱发卡
  1821. struct IssueFromBoxJSTask : public ITaskSp
  1822. {
  1823. CCardIssuerFSM* fsm;
  1824. SpReqAnsContext<CardIssuerStoreService_IssueFromBoxJS_Req, CardIssuerStoreService_IssueFromBoxJS_Ans>::Pointer ctx;
  1825. IssueFromBoxJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1826. void Process()
  1827. {
  1828. FSMEvent* e = new FSMEvent(USER_EVT_JS_ISSUE_FROM_BOX_FINISHED);
  1829. e->param1 = fsm->IssueFromBoxJS(ctx);
  1830. fsm->PostEventFIFO(e);
  1831. }
  1832. };
  1833. //跨机激活
  1834. struct PreOnlineCrossJSTask : public ITaskSp
  1835. {
  1836. CCardIssuerFSM* fsm;
  1837. SpReqAnsContext<CardIssuerStoreService_PreOnlineCrossJS_Req, CardIssuerStoreService_PreOnlineCrossJS_Ans>::Pointer ctx;
  1838. PreOnlineCrossJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1839. void Process()
  1840. {
  1841. FSMEvent* e = new FSMEvent(USER_EVT_JS_PREONLINE_CROSS_FINISHED);
  1842. e->param1 = fsm->PreOnlineCrossJS(ctx);
  1843. fsm->PostEventFIFO(e);
  1844. }
  1845. };
  1846. //读卡
  1847. struct ReadJSTask : public ITaskSp
  1848. {
  1849. CCardIssuerFSM* fsm;
  1850. SpReqAnsContext<CardIssuerStoreService_ReadJS_Req, CardIssuerStoreService_ReadJS_Ans>::Pointer ctx;
  1851. ReadJSTask(CCardIssuerFSM* f) : fsm(f) {}
  1852. void Process()
  1853. {
  1854. FSMEvent* e = new FSMEvent(USER_EVT_JS_READ_FINISHED);
  1855. e->param1 = fsm->ReadJS(ctx);
  1856. fsm->PostEventFIFO(e);
  1857. }
  1858. };
  1859. //故障自检task
  1860. struct QuickSelfcheckTask : public ITaskSp
  1861. {
  1862. CCardIssuerFSM* fsm;
  1863. QuickSelfcheckTask(CCardIssuerFSM* f) : fsm(f) {}
  1864. void Process()
  1865. {
  1866. QuickSelfcheckFinishEvent* e = new QuickSelfcheckFinishEvent();
  1867. Sleep(fsm->m_SelfcheckSleepTime);
  1868. e->param1 = fsm->QuickSelfCheckImpl();
  1869. fsm->PostEventFIFO(e);
  1870. }
  1871. };
  1872. struct GetCardInStoreJSTask : public ITaskSp
  1873. {
  1874. CCardIssuerFSM* fsm;
  1875. SpReqAnsContext<CardIssuerStoreService_GetCardInStoreJS_Req, CardIssuerStoreService_GetCardInStoreJS_Ans>::Pointer ctx;
  1876. GetCardInStoreJSTask(CCardIssuerFSM* f) : fsm(f) { ctx = NULL; }
  1877. void Process()
  1878. {
  1879. if (ctx != NULL) {
  1880. fsm->GetCardInStoreJS(ctx);
  1881. }
  1882. }
  1883. };
  1884. struct QueryHasCardJSTask : public ITaskSp
  1885. {
  1886. CCardIssuerFSM* fsm;
  1887. SpReqAnsContext<CardIssuerStoreService_QueryHasCardJS_Req, CardIssuerStoreService_QueryHasCardJS_Ans>::Pointer ctx;
  1888. QueryHasCardJSTask(CCardIssuerFSM* f) : fsm(f) { ctx = NULL; }
  1889. void Process()
  1890. {
  1891. if (ctx != NULL) {
  1892. fsm->QueryHasCardJS(ctx);
  1893. }
  1894. }
  1895. };
  1896. #pragma endregion JS接口 工作线程
  1897. #endif //__CARD_ISSUER_FSM_H