CardIssuerFSM.h 62 KB

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