mod_cardissuer.h 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661
  1. #include "CardIssuerStore_server_g.h"
  2. #include "CardIssuerStore_def_g.h"
  3. #include "CardIssuerFSM.h"
  4. #include "DevEntityCommBase.hpp"
  5. using namespace CardIssuerStore;
  6. class CCardIssuerEntity;
  7. class CardIssuerStoreServerSession : public CardIssuerStoreService_ServerSessionBase
  8. {
  9. public:
  10. CardIssuerStoreServerSession(CCardIssuerEntity* pEntity):m_pEntity(pEntity){}
  11. virtual ~CardIssuerStoreServerSession(){}
  12. virtual void Handle_Read(SpReqAnsContext<CardIssuerStoreService_Read_Req, CardIssuerStoreService_Read_Ans>::Pointer ctx);
  13. virtual void Handle_Capture(SpReqAnsContext<CardIssuerStoreService_Capture_Req, CardIssuerStoreService_Capture_Ans>::Pointer ctx);
  14. virtual void Handle_Eject(SpReqAnsContext<CardIssuerStoreService_Eject_Req, CardIssuerStoreService_Eject_Ans>::Pointer ctx);
  15. virtual void Handle_PreOnline(SpReqAnsContext<CardIssuerStoreService_PreOnline_Req, CardIssuerStoreService_PreOnline_Ans>::Pointer ctx);
  16. virtual void Handle_PostOnline(SpReqAnsContext<CardIssuerStoreService_PostOnline_Req, CardIssuerStoreService_PostOnline_Ans>::Pointer ctx);
  17. virtual void Handle_Exit(SpOnewayCallContext<CardIssuerStoreService_Exit_Info>::Pointer ctx);
  18. virtual void Handle_SetIssueFlag(SpOnewayCallContext<CardIssuerStoreService_SetIssueFlag_Info>::Pointer ctx);
  19. virtual void Handle_QueryCardInfo(SpReqAnsContext<CardIssuerStoreService_QueryCardInfo_Req, CardIssuerStoreService_QueryCardInfo_Ans>::Pointer ctx);
  20. virtual void Handle_WriteTrack(SpReqAnsContext<CardIssuerStoreService_WriteTrack_Req, CardIssuerStoreService_WriteTrack_Ans>::Pointer ctx);
  21. virtual void Handle_GetMaterialCountEx(SpReqAnsContext<CardIssuerStoreService_GetMaterialCountEx_Req, CardIssuerStoreService_GetMaterialCountEx_Ans>::Pointer ctx);
  22. virtual void Handle_SetMaterialCountEx(SpReqAnsContext<CardIssuerStoreService_SetMaterialCountEx_Req, CardIssuerStoreService_SetMaterialCountEx_Ans>::Pointer ctx);
  23. virtual void Handle_SetSomeFlag(SpReqAnsContext<CardIssuerStoreService_SetSomeFlag_Req, CardIssuerStoreService_SetSomeFlag_Ans>::Pointer ctx);
  24. virtual void Handle_IssueEx(SpReqAnsContext<CardIssuerStoreService_IssueEx_Req, CardIssuerStoreService_IssueEx_Ans>::Pointer ctx);
  25. virtual void Handle_SAMICCommand(SpReqAnsContext<CardIssuerStoreService_SAMICCommand_Req, CardIssuerStoreService_SAMICCommand_Ans>::Pointer ctx);
  26. virtual void Handle_QueryCardInfoOnStore(SpReqAnsContext<CardIssuerStoreService_QueryCardInfoOnStore_Req, CardIssuerStoreService_QueryCardInfoOnStore_Ans>::Pointer ctx);
  27. virtual void Handle_GetAddCardInfo(SpReqAnsContext<CardIssuerStoreService_GetAddCardInfo_Req, CardIssuerStoreService_GetAddCardInfo_Ans>::Pointer ctx);
  28. virtual void Handle_PrintCardImmediately(SpReqAnsContext<CardIssuerStoreService_PrintCardImmediately_Req, CardIssuerStoreService_PrintCardImmediately_Ans>::Pointer ctx);
  29. virtual void Handle_QueryCIStatus(SpReqAnsContext<CardIssuerStoreService_QueryCIStatus_Req, CardIssuerStoreService_QueryCIStatus_Ans>::Pointer ctx);
  30. virtual void Handle_GetDevInfo(SpReqAnsContext<CardIssuerStoreService_GetDevInfo_Req, CardIssuerStoreService_GetDevInfo_Ans>::Pointer ctx);
  31. //JS接口定义
  32. virtual void Handle_ReadJS(SpReqAnsContext<CardIssuerStoreService_ReadJS_Req, CardIssuerStoreService_ReadJS_Ans>::Pointer ctx);
  33. virtual void Handle_PostOnlineJS(SpReqAnsContext<CardIssuerStoreService_PostOnlineJS_Req, CardIssuerStoreService_PostOnlineJS_Ans>::Pointer ctx);
  34. virtual void Handle_EjectJS(SpReqAnsContext<CardIssuerStoreService_EjectJS_Req, CardIssuerStoreService_EjectJS_Ans>::Pointer ctx);
  35. virtual void Handle_CaptureJS(SpReqAnsContext<CardIssuerStoreService_CaptureJS_Req, CardIssuerStoreService_CaptureJS_Ans>::Pointer ctx);
  36. //virtual void Handle_QueryInternalHasCardJS(SpReqAnsContext<CardIssuerStoreService_QueryInternalHasCardJS_Req, CardIssuerStoreService_QueryInternalHasCardJS_Ans>::Pointer ctx);
  37. virtual void Handle_QueryHasCardJS(SpReqAnsContext<CardIssuerStoreService_QueryHasCardJS_Req, CardIssuerStoreService_QueryHasCardJS_Ans>::Pointer ctx);
  38. virtual void Handle_IssueFromBoxJS(SpReqAnsContext<CardIssuerStoreService_IssueFromBoxJS_Req, CardIssuerStoreService_IssueFromBoxJS_Ans>::Pointer ctx);
  39. //virtual void Handle_IssueFromSlotJS(SpReqAnsContext<CardIssuerStoreService_IssueFromSlotJS_Req, CardIssuerStoreService_IssueFromSlotJS_Ans>::Pointer ctx);
  40. //virtual void Handle_SAMICCommandJS(SpReqAnsContext<CardIssuerStoreService_SAMICCommandJS_Req, CardIssuerStoreService_SAMICCommandJS_Ans>::Pointer ctx);
  41. virtual void Handle_ICCommandJS(SpReqAnsContext<CardIssuerStoreService_ICCommandJS_Req, CardIssuerStoreService_ICCommandJS_Ans>::Pointer ctx);
  42. virtual void Handle_WriteTrackJS(SpReqAnsContext<CardIssuerStoreService_WriteTrackJS_Req, CardIssuerStoreService_WriteTrackJS_Ans>::Pointer ctx);
  43. virtual void Handle_PrintCardImmediatelyJS(SpReqAnsContext<CardIssuerStoreService_PrintCardImmediatelyJS_Req, CardIssuerStoreService_PrintCardImmediatelyJS_Ans>::Pointer ctx);
  44. virtual void Handle_PreOnlineCrossJS(SpReqAnsContext<CardIssuerStoreService_PreOnlineCrossJS_Req, CardIssuerStoreService_PreOnlineCrossJS_Ans>::Pointer ctx);
  45. virtual void Handle_ReadBatchCardInfoInRangeJS(SpReqAnsContext<CardIssuerStoreService_ReadBatchCardInfoInRangeJS_Req, CardIssuerStoreService_ReadBatchCardInfoInRangeJS_Ans>::Pointer ctx);
  46. virtual void Handle_GetCardInStoreJS(SpReqAnsContext<CardIssuerStoreService_GetCardInStoreJS_Req, CardIssuerStoreService_GetCardInStoreJS_Ans>::Pointer ctx);
  47. virtual void Handle_AddAndReadCardFromBoxJS(SpReqAnsContext<CardIssuerStoreService_AddAndReadCardFromBoxJS_Req, CardIssuerStoreService_AddAndReadCardFromBoxJS_Ans>::Pointer ctx);
  48. virtual void Handle_MoveAndReadCardFromSlotJS(SpReqAnsContext<CardIssuerStoreService_MoveAndReadCardFromSlotJS_Req, CardIssuerStoreService_MoveAndReadCardFromSlotJS_Ans>::Pointer ctx);
  49. virtual void Handle_MoveBacktoSlotJS(SpReqAnsContext<CardIssuerStoreService_MoveBacktoSlotJS_Req, CardIssuerStoreService_MoveBacktoSlotJS_Ans>::Pointer ctx);
  50. //新增接口
  51. virtual void Handle_AddCardFromBoxJS(SpReqAnsContext<CardIssuerStoreService_AddCardFromBoxJS_Req, CardIssuerStoreService_AddCardFromBoxJS_Ans>::Pointer ctx);
  52. virtual void Handle_MoveCardFromSlotJS(SpReqAnsContext<CardIssuerStoreService_MoveCardFromSlotJS_Req, CardIssuerStoreService_MoveCardFromSlotJS_Ans>::Pointer ctx);
  53. private:
  54. CCardIssuerEntity* m_pEntity;
  55. };
  56. class CCardIssuerEntity : public CDevAdptEntityBase, public ISysVarListener
  57. {
  58. public:
  59. CCardIssuerEntity() :bInitialized(false)
  60. {
  61. }
  62. virtual ~CCardIssuerEntity(){}
  63. virtual const char *GetEntityName() const { return "CardIssuerStore"; }
  64. virtual void OnPreStart(CAutoArray<CSimpleStringA> strArgs,CSmartPointer<ITransactionContext> pTransactionContext)
  65. {
  66. LOG_FUNCTION();
  67. ErrorCodeEnum eStart = m_fsm.Init(this);
  68. if (eStart == Error_Succeed)
  69. {
  70. }
  71. GetFunction()->RegistSysVarEvent("UIState", this);
  72. pTransactionContext->SendAnswer(eStart);
  73. }
  74. virtual void OnPreClose(EntityCloseCauseEnum eCloseCause,CSmartPointer<ITransactionContext> pTransactionContext)
  75. {
  76. ErrorCodeEnum Error = __OnStart(Error_Succeed);
  77. pTransactionContext->SendAnswer(Error);
  78. }
  79. virtual void OnPrePause(CSmartPointer<ITransactionContext> pTransactionContext)
  80. {
  81. ErrorCodeEnum Error = __OnPause(Error_Succeed,pTransactionContext);
  82. pTransactionContext->SendAnswer(Error);
  83. }
  84. virtual ErrorCodeEnum __OnStart(ErrorCodeEnum preOperationError)
  85. {
  86. return Error_Succeed;
  87. }
  88. virtual ErrorCodeEnum __OnPause(ErrorCodeEnum preOperationError, CSmartPointer<ITransactionContext> pTransactionContext)
  89. {
  90. return Error_Succeed;
  91. }
  92. virtual ErrorCodeEnum __OnClose(ErrorCodeEnum preOperationError)
  93. {
  94. return Error_Succeed;
  95. }
  96. virtual void OnSelfTest(EntityTestEnum eTestType,CSmartPointer<ITransactionContext> pTransactionContext)
  97. {
  98. m_fsm.SelfTest(eTestType,pTransactionContext);
  99. }
  100. virtual CServerSessionBase* OnNewSession(const char*,const char*)
  101. {
  102. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("A new connecting request arrived.");
  103. m_bNewSessionInit = true;
  104. return new CardIssuerStoreServerSession(this);
  105. }
  106. void Read(SpReqAnsContext<CardIssuerStoreService_Read_Req, CardIssuerStoreService_Read_Ans>::Pointer ctx)
  107. {
  108. LOG_FUNCTION();
  109. CardReadEvent* e = new CardReadEvent();
  110. e->ctx = ctx;
  111. m_fsm.PostEventFIFO(e);
  112. }
  113. void Capture(SpReqAnsContext<CardIssuerStoreService_Capture_Req, CardIssuerStoreService_Capture_Ans>::Pointer ctx)
  114. {
  115. LOG_FUNCTION();
  116. CardCaptureEvent* e = new CardCaptureEvent();
  117. e->ctx = ctx;
  118. m_fsm.PostEventFIFO(e);
  119. }
  120. void Eject(SpReqAnsContext<CardIssuerStoreService_Eject_Req, CardIssuerStoreService_Eject_Ans>::Pointer ctx)
  121. {
  122. LOG_FUNCTION();
  123. CardEjectEvent* e = new CardEjectEvent();
  124. e->ctx = ctx;
  125. m_fsm.PostEventFIFO(e);
  126. }
  127. void PreOnline(SpReqAnsContext<CardIssuerStoreService_PreOnline_Req, CardIssuerStoreService_PreOnline_Ans>::Pointer ctx)
  128. {
  129. LOG_FUNCTION();
  130. if (!m_fsm.GetDevInitFlag()) {
  131. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  132. }
  133. else {
  134. if (ctx->Req.reserved1.GetLength() > 0 && strnicmp("kaku#", (const char*)ctx->Req.reserved1, 5) == 0)
  135. {
  136. int state = m_fsm.GetFSMState();
  137. if (state == 9)
  138. {
  139. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_EntityInFailState);
  140. return;
  141. }
  142. else if (state != 2 || m_fsm.CheckIsCrossPreOnline())//借用跨机标识来识别是否跨机中
  143. {
  144. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_CardActive_CardStore_Issuing);
  145. return;
  146. }
  147. }
  148. PreOnlineEvent* e = new PreOnlineEvent();
  149. e->ctx = ctx;
  150. m_fsm.PostEventFIFO(e);
  151. }
  152. }
  153. void PostOnline(SpReqAnsContext<CardIssuerStoreService_PostOnline_Req, CardIssuerStoreService_PostOnline_Ans>::Pointer ctx)
  154. {
  155. LOG_FUNCTION();
  156. PostOnlineEvent* e = new PostOnlineEvent();
  157. e->ctx = ctx;
  158. m_fsm.PostEventFIFO(e);
  159. }
  160. void Exit(SpOnewayCallContext<CardIssuerStoreService_Exit_Info>::Pointer ctx)
  161. {
  162. LOG_FUNCTION();
  163. m_bNewSessionInit = false;
  164. FSMEvent *evt = new FSMEvent(USER_EVT_EXIT);
  165. m_fsm.PostEventFIFO(evt);
  166. }
  167. void QueryCardInfo(SpReqAnsContext<CardIssuerStoreService_QueryCardInfo_Req, CardIssuerStoreService_QueryCardInfo_Ans>::Pointer ctx)
  168. {
  169. if (m_bNewSessionInit)
  170. {
  171. FSMEvent *pEvt = new FSMEvent(USER_EVT_EXIT);
  172. m_fsm.PostEventFIFO(pEvt);
  173. ctx->Ans.position = CI_MEDIA_NOTPRESENT;
  174. ctx->Answer(Error_Succeed);
  175. }
  176. else
  177. {
  178. ctx->Ans.position = m_fsm.QueryCardInfo();
  179. ctx->Answer(Error_Succeed);
  180. }
  181. }
  182. void WriteTrack(SpReqAnsContext<CardIssuerStoreService_WriteTrack_Req, CardIssuerStoreService_WriteTrack_Ans>::Pointer ctx)
  183. {
  184. CardWriteEvent *pEvt = new CardWriteEvent();
  185. pEvt->ctx = ctx;
  186. m_fsm.PostEventFIFO(pEvt);
  187. }
  188. void SetIssueFlag(SpOnewayCallContext<CardIssuerStoreService_SetIssueFlag_Info>::Pointer ctx){ m_fsm.FrontSetIssueFlag(true); }
  189. void GetMaterialCountEx(SpReqAnsContext<CardIssuerStoreService_GetMaterialCountEx_Req, CardIssuerStoreService_GetMaterialCountEx_Ans>::Pointer ctx)
  190. {
  191. m_bNewSessionInit = false;
  192. GetMaterialExEvent *pEvt = new GetMaterialExEvent();
  193. pEvt->ctx = ctx;
  194. m_fsm.PostEventFIFO(pEvt);
  195. }
  196. void SetMaterialCountEx(SpReqAnsContext<CardIssuerStoreService_SetMaterialCountEx_Req, CardIssuerStoreService_SetMaterialCountEx_Ans>::Pointer ctx)
  197. {
  198. m_bNewSessionInit = false;
  199. SetMaterialExEvent *pEvt = new SetMaterialExEvent();
  200. pEvt->ctx = ctx;
  201. m_fsm.PostEventFIFO(pEvt);
  202. }
  203. void SetSomeFlag(SpReqAnsContext<CardIssuerStoreService_SetSomeFlag_Req, CardIssuerStoreService_SetSomeFlag_Ans>::Pointer ctx)
  204. {
  205. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("set issue flag to %d", ctx->Req.IssueBusiness);
  206. if (ctx->Req.IssueBusiness == 1)
  207. m_fsm.FrontSetIssueFlag(true);
  208. else if (ctx->Req.IssueBusiness == 0)
  209. m_fsm.FrontSetIssueFlag(false);
  210. else if (ctx->Req.IssueBusiness == 2)//oilyang@20170621 query issue direction
  211. {
  212. ctx->Ans.reserved1.Init(1);
  213. ctx->Ans.reserved1[0] = (m_fsm.QueryIssueFlag() ? 0 : 1);//according to yzx
  214. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("issue direction:%d",ctx->Ans.reserved1[0]);//if 0 capture card eles eject card
  215. }
  216. else if (ctx->Req.IssueBusiness == 3)//oilyang@20181210
  217. {
  218. m_fsm.SetCancelByRFICFlag();
  219. }
  220. else if (ctx->Req.IssueBusiness == 4)//oilyang@20181220 get ic card account,for simple/lazy...
  221. {
  222. ctx->Ans.reserved2.Init(1);
  223. ctx->Ans.reserved2[0] = m_fsm.GetPreOnlineICCardNo();
  224. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetPreOnlineICCardNo:%d", ctx->Ans.reserved2[0].GetLength());
  225. }
  226. if (ctx->Req.reserved1.GetCount() > 0)
  227. {
  228. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("set hopper num:%d",ctx->Req.reserved1[0]);
  229. if (ctx->Req.reserved1[0] == 1)
  230. m_fsm.SetHopperNum(1);
  231. else if (ctx->Req.reserved1[0] == 3)
  232. m_fsm.SetHopperNum(3);
  233. }
  234. ctx->Answer(Error_Succeed);
  235. }
  236. void IssueEx(SpReqAnsContext<CardIssuerStoreService_IssueEx_Req, CardIssuerStoreService_IssueEx_Ans>::Pointer ctx)
  237. {
  238. LOG_FUNCTION();
  239. if (!m_fsm.GetDevInitFlag()) {
  240. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  241. }
  242. else {
  243. m_bNewSessionInit = false;
  244. CardIssueExEvent* pEvt = new CardIssueExEvent();
  245. pEvt->ctx = ctx;
  246. m_fsm.PostEventFIFO(pEvt);
  247. }
  248. }
  249. void SAMICCommand(SpReqAnsContext<CardIssuerStoreService_SAMICCommand_Req, CardIssuerStoreService_SAMICCommand_Ans>::Pointer ctx)
  250. {
  251. LOG_FUNCTION();
  252. SAMICCommandEvent *pEvt = new SAMICCommandEvent();
  253. pEvt->ctx = ctx;
  254. m_fsm.PostEventFIFO(pEvt);
  255. }
  256. void QueryCardInfoOnStore(SpReqAnsContext<CardIssuerStoreService_QueryCardInfoOnStore_Req, CardIssuerStoreService_QueryCardInfoOnStore_Ans>::Pointer ctx)
  257. {
  258. if (!m_fsm.GetDevInitFlag()) {
  259. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  260. }
  261. else
  262. {
  263. QueryCardInfoOnStoreEvent* pEvt = new QueryCardInfoOnStoreEvent();
  264. pEvt->ctx = ctx;
  265. m_fsm.PostEventFIFO(pEvt);
  266. }
  267. }
  268. void GetAddCardInfo(SpReqAnsContext<CardIssuerStoreService_GetAddCardInfo_Req, CardIssuerStoreService_GetAddCardInfo_Ans>::Pointer ctx)
  269. {
  270. if (!m_fsm.GetDevInitFlag()) {
  271. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  272. }
  273. else
  274. {
  275. m_fsm.GetAddCardInfo(ctx);
  276. }
  277. }
  278. void PrintCardImmediately(SpReqAnsContext<CardIssuerStoreService_PrintCardImmediately_Req, CardIssuerStoreService_PrintCardImmediately_Ans>::Pointer ctx)
  279. {
  280. LOG_FUNCTION();
  281. PrintCardImEvent* pEvt = new PrintCardImEvent();
  282. pEvt->ctx = ctx;
  283. m_fsm.PostEventFIFO(pEvt);
  284. }
  285. void GetDevInfo(SpReqAnsContext<CardIssuerStoreService_GetDevInfo_Req, CardIssuerStoreService_GetDevInfo_Ans>::Pointer ctx)
  286. {
  287. LOG_FUNCTION();
  288. ctx->Ans.state = m_fsm.GetDevState();
  289. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetDevInfo state=%d", ctx->Ans.state);
  290. if (m_fsm.GetDevInitingFlag()) {
  291. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetDevInfo device is opening,state return 0");
  292. ctx->Ans.state = DEVICE_STATUS_NOT_READY;
  293. ctx->Answer(Error_NotInit, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  294. }
  295. else {
  296. //设备未正常打开时,直接报state=0;
  297. if (!m_fsm.GetDevInitFlag()) {
  298. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetDevInfo device is not open,state return 0");
  299. ctx->Ans.state = DEVICE_STATUS_NOT_READY;
  300. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  301. }
  302. else {
  303. ctx->Answer(Error_Succeed);
  304. }
  305. }
  306. }
  307. void QueryCIStatus(SpReqAnsContext<CardIssuerStoreService_QueryCIStatus_Req, CardIssuerStoreService_QueryCIStatus_Ans>::Pointer ctx)
  308. {
  309. m_fsm.QueryCIStatus(ctx);
  310. }
  311. //实体具体接口实现
  312. void EjectJS(SpReqAnsContext<CardIssuerStoreService_EjectJS_Req, CardIssuerStoreService_EjectJS_Ans>::Pointer ctx)
  313. {
  314. LOG_FUNCTION();
  315. if (!m_fsm.GetDevInitFlag()) {
  316. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  317. }
  318. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  319. //不符合请求调用,告知具体错误流程
  320. DWORD errCode = m_fsm.GetFsmStateErrCode();
  321. int state = m_fsm.GetFSMState();
  322. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("EjectJS req is unhandled ,CurrState=%d",state);
  323. ctx->Answer(Error_Unexpect, errCode);
  324. }
  325. else {
  326. EjectJSEvent* e = new EjectJSEvent();
  327. e->ctx = ctx;
  328. m_fsm.PostEventFIFO(e);
  329. }
  330. }
  331. void CaptureJS(SpReqAnsContext<CardIssuerStoreService_CaptureJS_Req, CardIssuerStoreService_CaptureJS_Ans>::Pointer ctx)
  332. {
  333. LOG_FUNCTION();
  334. if (!m_fsm.GetDevInitFlag()) {
  335. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  336. }
  337. else if(_stricmp(m_fsm.GetCurrStateName(), "Hold") == 0 || _stricmp(m_fsm.GetCurrStateName(), "Idle") == 0){
  338. CaptureJSEvent* e = new CaptureJSEvent();
  339. e->ctx = ctx;
  340. m_fsm.PostEventFIFO(e);
  341. }
  342. else {
  343. //不符合请求调用,告知具体错误流程
  344. DWORD errCode = m_fsm.GetFsmStateErrCode();
  345. int state = m_fsm.GetFSMState();
  346. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("CaptureJS req is unhandled ,CurrState=%d", state);
  347. ctx->Answer(Error_Unexpect, errCode);
  348. }
  349. }
  350. void ReadBatchCardInfoInRangeJS(SpReqAnsContext<CardIssuerStoreService_ReadBatchCardInfoInRangeJS_Req, CardIssuerStoreService_ReadBatchCardInfoInRangeJS_Ans>::Pointer ctx)
  351. {
  352. LOG_FUNCTION();
  353. if (!m_fsm.GetDevInitFlag()) {
  354. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  355. }
  356. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  357. //不符合请求调用,告知具体错误流程
  358. DWORD errCode = m_fsm.GetFsmStateErrCode();
  359. int state = m_fsm.GetFSMState();
  360. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("ReadBatchCardInfoInRangeJS req is unhandled ,CurrState=%d", state);
  361. ctx->Answer(Error_Unexpect, errCode);
  362. }
  363. else {
  364. ReadBatchCardInfoInRangeJSEvent* pEvt = new ReadBatchCardInfoInRangeJSEvent();
  365. pEvt->ctx = ctx;
  366. m_fsm.PostEventFIFO(pEvt);
  367. }
  368. }
  369. void GetCardInStoreJS(SpReqAnsContext<CardIssuerStoreService_GetCardInStoreJS_Req, CardIssuerStoreService_GetCardInStoreJS_Ans>::Pointer ctx)
  370. {
  371. LOG_FUNCTION();
  372. if (!m_fsm.GetDevInitFlag()) {
  373. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  374. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("GetCardInStoreJS but DevOpen failed.");
  375. }
  376. else {
  377. m_fsm.GetCardInStoreJS(ctx);
  378. }
  379. }
  380. void AddAndReadCardFromBoxJS(SpReqAnsContext<CardIssuerStoreService_AddAndReadCardFromBoxJS_Req, CardIssuerStoreService_AddAndReadCardFromBoxJS_Ans>::Pointer ctx)
  381. {
  382. LOG_FUNCTION();
  383. if (!m_fsm.GetDevInitFlag()) {
  384. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  385. }
  386. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  387. //不符合请求调用,告知具体错误流程
  388. DWORD errCode = m_fsm.GetFsmStateErrCode();
  389. int state = m_fsm.GetFSMState();
  390. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("AddAndReadCardFromBoxJS req is unhandled ,CurrState=%d", state);
  391. ctx->Answer(Error_Unexpect, errCode);
  392. }
  393. else {
  394. AddAndReadCardFromBoxJSEvent* pEvt = new AddAndReadCardFromBoxJSEvent();
  395. pEvt->ctx = ctx;
  396. m_fsm.PostEventFIFO(pEvt);
  397. }
  398. }
  399. void AddCardFromBoxJS(SpReqAnsContext<CardIssuerStoreService_AddCardFromBoxJS_Req, CardIssuerStoreService_AddCardFromBoxJS_Ans>::Pointer ctx)
  400. {
  401. LOG_FUNCTION();
  402. if (!m_fsm.GetDevInitFlag()) {
  403. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  404. }
  405. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  406. //不符合请求调用,告知具体错误流程
  407. DWORD errCode = m_fsm.GetFsmStateErrCode();
  408. int state = m_fsm.GetFSMState();
  409. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("AddCardFromBoxJS req is unhandled ,CurrState=%d", state);
  410. ctx->Answer(Error_Unexpect, errCode);
  411. }
  412. else {
  413. AddCardFromBoxJSEvent* pEvt = new AddCardFromBoxJSEvent();
  414. pEvt->ctx = ctx;
  415. m_fsm.PostEventFIFO(pEvt);
  416. }
  417. }
  418. void MoveAndReadCardFromSlotJS(SpReqAnsContext<CardIssuerStoreService_MoveAndReadCardFromSlotJS_Req, CardIssuerStoreService_MoveAndReadCardFromSlotJS_Ans>::Pointer ctx)
  419. {
  420. LOG_FUNCTION();
  421. if (!m_fsm.GetDevInitFlag()) {
  422. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  423. }
  424. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  425. //不符合请求调用,告知具体错误流程
  426. DWORD errCode = m_fsm.GetFsmStateErrCode();
  427. int state = m_fsm.GetFSMState();
  428. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("MoveAndReadCardFromSlotJS req is unhandled ,CurrState=%d", state);
  429. ctx->Answer(Error_Unexpect, errCode);
  430. }
  431. else {
  432. MoveAndReadCardFromSlotJSEvent* pEvt = new MoveAndReadCardFromSlotJSEvent();
  433. pEvt->ctx = ctx;
  434. m_fsm.PostEventFIFO(pEvt);
  435. }
  436. }
  437. void MoveCardFromSlotJS(SpReqAnsContext<CardIssuerStoreService_MoveCardFromSlotJS_Req, CardIssuerStoreService_MoveCardFromSlotJS_Ans>::Pointer ctx)
  438. {
  439. LOG_FUNCTION();
  440. if (!m_fsm.GetDevInitFlag()) {
  441. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  442. }
  443. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  444. //不符合请求调用,告知具体错误流程
  445. DWORD errCode = m_fsm.GetFsmStateErrCode();
  446. int state = m_fsm.GetFSMState();
  447. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("MoveCardFromSlotJS req is unhandled ,CurrState=%d", state);
  448. ctx->Answer(Error_Unexpect, errCode);
  449. }
  450. else {
  451. MoveCardFromSlotJSEvent* pEvt = new MoveCardFromSlotJSEvent();
  452. pEvt->ctx = ctx;
  453. m_fsm.PostEventFIFO(pEvt);
  454. }
  455. }
  456. void MoveBacktoSlotJS(SpReqAnsContext<CardIssuerStoreService_MoveBacktoSlotJS_Req, CardIssuerStoreService_MoveBacktoSlotJS_Ans>::Pointer ctx)
  457. {
  458. LOG_FUNCTION();
  459. if (!m_fsm.GetDevInitFlag()) {
  460. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  461. }
  462. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  463. //不符合请求调用,告知具体错误流程
  464. DWORD errCode = m_fsm.GetFsmStateErrCode();
  465. int state = m_fsm.GetFSMState();
  466. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("MoveBacktoSlotJS req is unhandled ,CurrState=%d", state);
  467. ctx->Answer(Error_Unexpect, errCode);
  468. }
  469. else {
  470. MoveBacktoSlotJSEvent* pEvt = new MoveBacktoSlotJSEvent();
  471. pEvt->ctx = ctx;
  472. m_fsm.PostEventFIFO(pEvt);
  473. }
  474. }
  475. void QueryHasCardJS(SpReqAnsContext<CardIssuerStoreService_QueryHasCardJS_Req, CardIssuerStoreService_QueryHasCardJS_Ans>::Pointer ctx)
  476. {
  477. LOG_FUNCTION();
  478. if (!m_fsm.GetDevInitFlag()) {
  479. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("QueryHasCardJS but DevOpen failed.");
  480. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  481. }
  482. else {
  483. m_fsm.QueryHasCardJS(ctx);
  484. }
  485. }
  486. void ICCommandJS(SpReqAnsContext<CardIssuerStoreService_ICCommandJS_Req, CardIssuerStoreService_ICCommandJS_Ans>::Pointer ctx)
  487. {
  488. LOG_FUNCTION();
  489. if (!m_fsm.GetDevInitFlag()) {
  490. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  491. }
  492. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  493. //不符合请求调用,告知具体错误流程
  494. DWORD errCode = m_fsm.GetFsmStateErrCode();
  495. int state = m_fsm.GetFSMState();
  496. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("ICCommandJS req is unhandled ,CurrState=%d", state);
  497. ctx->Answer(Error_Unexpect, errCode);
  498. }
  499. else {
  500. ICCommandJSEvent* pEvt = new ICCommandJSEvent();
  501. pEvt->ctx = ctx;
  502. m_fsm.PostEventFIFO(pEvt);
  503. }
  504. }
  505. void WriteTrackJS(SpReqAnsContext<CardIssuerStoreService_WriteTrackJS_Req, CardIssuerStoreService_WriteTrackJS_Ans>::Pointer ctx)
  506. {
  507. LOG_FUNCTION();
  508. if (!m_fsm.GetDevInitFlag()) {
  509. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  510. }
  511. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  512. //不符合请求调用,告知具体错误流程
  513. DWORD errCode = m_fsm.GetFsmStateErrCode();
  514. int state = m_fsm.GetFSMState();
  515. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("WriteTrackJS req is unhandled ,CurrState=%d", state);
  516. ctx->Answer(Error_Unexpect, errCode);
  517. }
  518. else {
  519. WriteTrackJSEvent* pEvt = new WriteTrackJSEvent();
  520. pEvt->ctx = ctx;
  521. m_fsm.PostEventFIFO(pEvt);
  522. }
  523. }
  524. void PrintCardImmediatelyJS(SpReqAnsContext<CardIssuerStoreService_PrintCardImmediatelyJS_Req, CardIssuerStoreService_PrintCardImmediatelyJS_Ans>::Pointer ctx)
  525. {
  526. LOG_FUNCTION();
  527. if (!m_fsm.GetDevInitFlag()) {
  528. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  529. }
  530. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  531. //不符合请求调用,告知具体错误流程
  532. DWORD errCode = m_fsm.GetFsmStateErrCode();
  533. int state = m_fsm.GetFSMState();
  534. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("PrintCardImmediatelyJS req is unhandled ,CurrState=%d", state);
  535. ctx->Answer(Error_Unexpect, errCode);
  536. }
  537. else {
  538. PrintCardImmediatelyJSEvent* pEvt = new PrintCardImmediatelyJSEvent();
  539. pEvt->ctx = ctx;
  540. m_fsm.PostEventFIFO(pEvt);
  541. }
  542. }
  543. void PostOnlineJS(SpReqAnsContext<CardIssuerStoreService_PostOnlineJS_Req, CardIssuerStoreService_PostOnlineJS_Ans>::Pointer ctx)
  544. {
  545. LOG_FUNCTION();
  546. if (!m_fsm.GetDevInitFlag()) {
  547. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  548. }
  549. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  550. //不符合请求调用,告知具体错误流程
  551. DWORD errCode = m_fsm.GetFsmStateErrCode();
  552. int state = m_fsm.GetFSMState();
  553. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("PostOnlineJS req is unhandled ,CurrState=%d", state);
  554. ctx->Answer(Error_Unexpect, errCode);
  555. }
  556. else {
  557. PostOnlineJSEvent* pEvt = new PostOnlineJSEvent();
  558. pEvt->ctx = ctx;
  559. m_fsm.PostEventFIFO(pEvt);
  560. }
  561. }
  562. void IssueFromBoxJS(SpReqAnsContext<CardIssuerStoreService_IssueFromBoxJS_Req, CardIssuerStoreService_IssueFromBoxJS_Ans>::Pointer ctx)
  563. {
  564. LOG_FUNCTION();
  565. if (!m_fsm.GetDevInitFlag()) {
  566. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  567. }
  568. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  569. //不符合请求调用,告知具体错误流程
  570. DWORD errCode = m_fsm.GetFsmStateErrCode();
  571. int state = m_fsm.GetFSMState();
  572. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("IssueFromBoxJS req is unhandled ,CurrState=%d", state);
  573. ctx->Answer(Error_Unexpect, errCode);
  574. }
  575. else {
  576. IssueFromBoxJSEvent* pEvt = new IssueFromBoxJSEvent();
  577. pEvt->ctx = ctx;
  578. m_fsm.PostEventFIFO(pEvt);
  579. }
  580. }
  581. void PreOnlineCrossJS(SpReqAnsContext<CardIssuerStoreService_PreOnlineCrossJS_Req, CardIssuerStoreService_PreOnlineCrossJS_Ans>::Pointer ctx)
  582. {
  583. LOG_FUNCTION();
  584. if (!m_fsm.GetDevInitFlag()) {
  585. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  586. }
  587. else if (_stricmp(m_fsm.GetCurrStateName(), "Failed") == 0) {
  588. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_EntityInFailState);
  589. return;
  590. }
  591. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0 || m_fsm.CheckIsCrossPreOnline()) {
  592. //不符合请求调用,告知具体错误流程
  593. DWORD errCode = m_fsm.GetFsmStateErrCode();
  594. int state = m_fsm.GetFSMState();
  595. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("PreOnlineCrossJS req is unhandled ,CurrState=%d", state);
  596. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_CardActive_CardStore_Issuing);
  597. return;
  598. }
  599. else {
  600. PreOnlineCrossJSEvent* pEvt = new PreOnlineCrossJSEvent();
  601. pEvt->ctx = ctx;
  602. m_fsm.PostEventFIFO(pEvt);
  603. }
  604. }
  605. void ReadJS(SpReqAnsContext<CardIssuerStoreService_ReadJS_Req, CardIssuerStoreService_ReadJS_Ans>::Pointer ctx)
  606. {
  607. LOG_FUNCTION();
  608. if (!m_fsm.GetDevInitFlag()) {
  609. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  610. }
  611. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  612. //不符合请求调用,告知具体错误流程
  613. DWORD errCode = m_fsm.GetFsmStateErrCode();
  614. int state = m_fsm.GetFSMState();
  615. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("ReadJS req is unhandled ,CurrState=%d", state);
  616. ctx->Answer(Error_Unexpect, errCode);
  617. }
  618. else {
  619. ReadJSEvent* pEvt = new ReadJSEvent();
  620. pEvt->ctx = ctx;
  621. m_fsm.PostEventFIFO(pEvt);
  622. }
  623. }
  624. virtual void OnSysVarEvent(const char* pszKey, const char* pszValue, const char* pszOldValue, const char* pszEntityName);
  625. virtual bool IsService()const{return true;}
  626. virtual bool IsMultiThread()const{return true;}
  627. protected:
  628. private:
  629. CCardIssuerFSM m_fsm;
  630. bool bInitialized,m_bNewSessionInit;
  631. };