CardIssuerFSM.h 52 KB

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