mod_cardissuerStore.h 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675
  1. #include "CardIssuerStore_server_g.h"
  2. #include "CardIssuerStore_def_g.h"
  3. #include "CardIssuerStoreFSM.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. else if (!m_fsm.IsInMainPage()) {//判断是否在首页
  148. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("PreOnline req is unhandled ,CardissuerStore is busying");
  149. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_CardActive_CardStore_Issuing);
  150. return;
  151. }
  152. }
  153. PreOnlineEvent* e = new PreOnlineEvent();
  154. e->ctx = ctx;
  155. m_fsm.PostEventFIFO(e);
  156. }
  157. }
  158. void PostOnline(SpReqAnsContext<CardIssuerStoreService_PostOnline_Req, CardIssuerStoreService_PostOnline_Ans>::Pointer ctx)
  159. {
  160. LOG_FUNCTION();
  161. PostOnlineEvent* e = new PostOnlineEvent();
  162. e->ctx = ctx;
  163. m_fsm.PostEventFIFO(e);
  164. }
  165. void Exit(SpOnewayCallContext<CardIssuerStoreService_Exit_Info>::Pointer ctx)
  166. {
  167. LOG_FUNCTION();
  168. m_bNewSessionInit = false;
  169. FSMEvent *evt = new FSMEvent(USER_EVT_EXIT);
  170. m_fsm.PostEventFIFO(evt);
  171. }
  172. void QueryCardInfo(SpReqAnsContext<CardIssuerStoreService_QueryCardInfo_Req, CardIssuerStoreService_QueryCardInfo_Ans>::Pointer ctx)
  173. {
  174. if (m_bNewSessionInit)
  175. {
  176. FSMEvent *pEvt = new FSMEvent(USER_EVT_EXIT);
  177. m_fsm.PostEventFIFO(pEvt);
  178. ctx->Ans.position = CI_MEDIA_NOTPRESENT;
  179. ctx->Answer(Error_Succeed);
  180. }
  181. else
  182. {
  183. ctx->Ans.position = m_fsm.QueryCardInfo();
  184. ctx->Answer(Error_Succeed);
  185. }
  186. }
  187. void WriteTrack(SpReqAnsContext<CardIssuerStoreService_WriteTrack_Req, CardIssuerStoreService_WriteTrack_Ans>::Pointer ctx)
  188. {
  189. CardWriteEvent *pEvt = new CardWriteEvent();
  190. pEvt->ctx = ctx;
  191. m_fsm.PostEventFIFO(pEvt);
  192. }
  193. void SetIssueFlag(SpOnewayCallContext<CardIssuerStoreService_SetIssueFlag_Info>::Pointer ctx){ m_fsm.FrontSetIssueFlag(true); }
  194. void GetMaterialCountEx(SpReqAnsContext<CardIssuerStoreService_GetMaterialCountEx_Req, CardIssuerStoreService_GetMaterialCountEx_Ans>::Pointer ctx)
  195. {
  196. m_bNewSessionInit = false;
  197. GetMaterialExEvent *pEvt = new GetMaterialExEvent();
  198. pEvt->ctx = ctx;
  199. m_fsm.PostEventFIFO(pEvt);
  200. }
  201. void SetMaterialCountEx(SpReqAnsContext<CardIssuerStoreService_SetMaterialCountEx_Req, CardIssuerStoreService_SetMaterialCountEx_Ans>::Pointer ctx)
  202. {
  203. m_bNewSessionInit = false;
  204. SetMaterialExEvent *pEvt = new SetMaterialExEvent();
  205. pEvt->ctx = ctx;
  206. m_fsm.PostEventFIFO(pEvt);
  207. }
  208. void SetSomeFlag(SpReqAnsContext<CardIssuerStoreService_SetSomeFlag_Req, CardIssuerStoreService_SetSomeFlag_Ans>::Pointer ctx)
  209. {
  210. //DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("set issue flag to %d", ctx->Req.IssueBusiness);
  211. if (ctx->Req.IssueBusiness == 1)
  212. m_fsm.FrontSetIssueFlag(true);
  213. else if (ctx->Req.IssueBusiness == 0)
  214. m_fsm.FrontSetIssueFlag(false);
  215. else if (ctx->Req.IssueBusiness == 2)//oilyang@20170621 query issue direction
  216. {
  217. ctx->Ans.reserved1.Init(1);
  218. ctx->Ans.reserved1[0] = (m_fsm.QueryIssueFlag() ? 0 : 1);//according to yzx
  219. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("issue direction:%d",ctx->Ans.reserved1[0]);//if 0 capture card eles eject card
  220. }
  221. else if (ctx->Req.IssueBusiness == 3)//oilyang@20181210
  222. {
  223. m_fsm.SetCancelByRFICFlag();
  224. }
  225. else if (ctx->Req.IssueBusiness == 4)//oilyang@20181220 get ic card account,for simple/lazy...
  226. {
  227. ctx->Ans.reserved2.Init(1);
  228. ctx->Ans.reserved2[0] = m_fsm.GetPreOnlineICCardNo();
  229. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetPreOnlineICCardNo:%d", ctx->Ans.reserved2[0].GetLength());
  230. }
  231. if (ctx->Req.reserved1.GetCount() > 0)
  232. {
  233. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("set hopper num:%d",ctx->Req.reserved1[0]);
  234. if (ctx->Req.reserved1[0] == 1)
  235. m_fsm.SetHopperNum(1);
  236. else if (ctx->Req.reserved1[0] == 3)
  237. m_fsm.SetHopperNum(3);
  238. }
  239. ctx->Answer(Error_Succeed);
  240. }
  241. void IssueEx(SpReqAnsContext<CardIssuerStoreService_IssueEx_Req, CardIssuerStoreService_IssueEx_Ans>::Pointer ctx)
  242. {
  243. LOG_FUNCTION();
  244. if (!m_fsm.GetDevInitFlag()) {
  245. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  246. }
  247. else {
  248. m_bNewSessionInit = false;
  249. CardIssueExEvent* pEvt = new CardIssueExEvent();
  250. pEvt->ctx = ctx;
  251. m_fsm.PostEventFIFO(pEvt);
  252. }
  253. }
  254. void SAMICCommand(SpReqAnsContext<CardIssuerStoreService_SAMICCommand_Req, CardIssuerStoreService_SAMICCommand_Ans>::Pointer ctx)
  255. {
  256. LOG_FUNCTION();
  257. SAMICCommandEvent *pEvt = new SAMICCommandEvent();
  258. pEvt->ctx = ctx;
  259. m_fsm.PostEventFIFO(pEvt);
  260. }
  261. void QueryCardInfoOnStore(SpReqAnsContext<CardIssuerStoreService_QueryCardInfoOnStore_Req, CardIssuerStoreService_QueryCardInfoOnStore_Ans>::Pointer ctx)
  262. {
  263. if (!m_fsm.GetDevInitFlag()) {
  264. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  265. }
  266. else
  267. {
  268. QueryCardInfoOnStoreEvent* pEvt = new QueryCardInfoOnStoreEvent();
  269. pEvt->ctx = ctx;
  270. m_fsm.PostEventFIFO(pEvt);
  271. }
  272. }
  273. void GetAddCardInfo(SpReqAnsContext<CardIssuerStoreService_GetAddCardInfo_Req, CardIssuerStoreService_GetAddCardInfo_Ans>::Pointer ctx)
  274. {
  275. if (!m_fsm.GetDevInitFlag()) {
  276. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  277. }
  278. else
  279. {
  280. m_fsm.GetAddCardInfo(ctx);
  281. }
  282. }
  283. void PrintCardImmediately(SpReqAnsContext<CardIssuerStoreService_PrintCardImmediately_Req, CardIssuerStoreService_PrintCardImmediately_Ans>::Pointer ctx)
  284. {
  285. LOG_FUNCTION();
  286. PrintCardImEvent* pEvt = new PrintCardImEvent();
  287. pEvt->ctx = ctx;
  288. m_fsm.PostEventFIFO(pEvt);
  289. }
  290. void GetDevInfo(SpReqAnsContext<CardIssuerStoreService_GetDevInfo_Req, CardIssuerStoreService_GetDevInfo_Ans>::Pointer ctx)
  291. {
  292. LOG_FUNCTION();
  293. ctx->Ans.state = m_fsm.GetDevState();
  294. if (m_fsm.GetDevInitingFlag()) {
  295. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetDevInfo device is opening,state return 0");
  296. ctx->Ans.state = DEVICE_STATUS_NOT_READY;
  297. ctx->Answer(Error_NotInit, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  298. }
  299. else {
  300. //设备未正常打开时,直接报state=0;
  301. if (!m_fsm.GetDevInitFlag()) {
  302. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetDevInfo device is not open,state return 0");
  303. ctx->Ans.state = DEVICE_STATUS_NOT_READY;
  304. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  305. }
  306. else {
  307. if (ctx->Ans.state != DEVICE_STATUS_NORMAL) {
  308. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetDevInfo state=%d", ctx->Ans.state);
  309. }
  310. ctx->Answer(Error_Succeed);
  311. }
  312. }
  313. }
  314. void QueryCIStatus(SpReqAnsContext<CardIssuerStoreService_QueryCIStatus_Req, CardIssuerStoreService_QueryCIStatus_Ans>::Pointer ctx)
  315. {
  316. m_fsm.QueryCIStatus(ctx);
  317. }
  318. //实体具体接口实现
  319. void EjectJS(SpReqAnsContext<CardIssuerStoreService_EjectJS_Req, CardIssuerStoreService_EjectJS_Ans>::Pointer ctx)
  320. {
  321. LOG_FUNCTION();
  322. if (!m_fsm.GetDevInitFlag()) {
  323. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  324. }
  325. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  326. //不符合请求调用,告知具体错误流程
  327. DWORD errCode = m_fsm.GetFsmStateErrCode();
  328. int state = m_fsm.GetFSMState();
  329. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode(m_fsm.getRTACode(errCode))("EjectJS req is unhandled ,CurrState=%d",state);
  330. ctx->Answer(Error_Unexpect, errCode);
  331. }
  332. else {
  333. EjectJSEvent* e = new EjectJSEvent();
  334. e->ctx = ctx;
  335. m_fsm.PostEventFIFO(e);
  336. }
  337. }
  338. void CaptureJS(SpReqAnsContext<CardIssuerStoreService_CaptureJS_Req, CardIssuerStoreService_CaptureJS_Ans>::Pointer ctx)
  339. {
  340. LOG_FUNCTION();
  341. if (!m_fsm.GetDevInitFlag()) {
  342. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  343. }
  344. else if(_stricmp(m_fsm.GetCurrStateName(), "Hold") == 0 || _stricmp(m_fsm.GetCurrStateName(), "Idle") == 0){
  345. CaptureJSEvent* e = new CaptureJSEvent();
  346. e->ctx = ctx;
  347. m_fsm.PostEventFIFO(e);
  348. }
  349. else {
  350. //不符合请求调用,告知具体错误流程
  351. DWORD errCode = m_fsm.GetFsmStateErrCode();
  352. int state = m_fsm.GetFSMState();
  353. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode(m_fsm.getRTACode(errCode))("CaptureJS req is unhandled ,CurrState=%d", state);
  354. ctx->Answer(Error_Unexpect, errCode);
  355. }
  356. }
  357. void ReadBatchCardInfoInRangeJS(SpReqAnsContext<CardIssuerStoreService_ReadBatchCardInfoInRangeJS_Req, CardIssuerStoreService_ReadBatchCardInfoInRangeJS_Ans>::Pointer ctx)
  358. {
  359. LOG_FUNCTION();
  360. if (!m_fsm.GetDevInitFlag()) {
  361. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  362. }
  363. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  364. //不符合请求调用,告知具体错误流程
  365. DWORD errCode = m_fsm.GetFsmStateErrCode();
  366. int state = m_fsm.GetFSMState();
  367. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode(m_fsm.getRTACode(errCode))("ReadBatchCardInfoInRangeJS req is unhandled ,CurrState=%d", state);
  368. ctx->Answer(Error_Unexpect, errCode);
  369. }
  370. else {
  371. ReadBatchCardInfoInRangeJSEvent* pEvt = new ReadBatchCardInfoInRangeJSEvent();
  372. pEvt->ctx = ctx;
  373. m_fsm.PostEventFIFO(pEvt);
  374. }
  375. }
  376. void GetCardInStoreJS(SpReqAnsContext<CardIssuerStoreService_GetCardInStoreJS_Req, CardIssuerStoreService_GetCardInStoreJS_Ans>::Pointer ctx)
  377. {
  378. LOG_FUNCTION();
  379. if (!m_fsm.GetDevInitFlag()) {
  380. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  381. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("GetCardInStoreJS but DevOpen failed.");
  382. }
  383. else {
  384. m_fsm.GetCardInStoreJS(ctx);
  385. }
  386. }
  387. void AddAndReadCardFromBoxJS(SpReqAnsContext<CardIssuerStoreService_AddAndReadCardFromBoxJS_Req, CardIssuerStoreService_AddAndReadCardFromBoxJS_Ans>::Pointer ctx)
  388. {
  389. LOG_FUNCTION();
  390. if (!m_fsm.GetDevInitFlag()) {
  391. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  392. }
  393. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  394. //不符合请求调用,告知具体错误流程
  395. DWORD errCode = m_fsm.GetFsmStateErrCode();
  396. int state = m_fsm.GetFSMState();
  397. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode(m_fsm.getRTACode(errCode))("AddAndReadCardFromBoxJS req is unhandled ,CurrState=%d", state);
  398. ctx->Answer(Error_Unexpect, errCode);
  399. }
  400. else {
  401. AddAndReadCardFromBoxJSEvent* pEvt = new AddAndReadCardFromBoxJSEvent();
  402. pEvt->ctx = ctx;
  403. m_fsm.PostEventFIFO(pEvt);
  404. }
  405. }
  406. void AddCardFromBoxJS(SpReqAnsContext<CardIssuerStoreService_AddCardFromBoxJS_Req, CardIssuerStoreService_AddCardFromBoxJS_Ans>::Pointer ctx)
  407. {
  408. LOG_FUNCTION();
  409. if (!m_fsm.GetDevInitFlag()) {
  410. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  411. }
  412. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  413. //不符合请求调用,告知具体错误流程
  414. DWORD errCode = m_fsm.GetFsmStateErrCode();
  415. int state = m_fsm.GetFSMState();
  416. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode(m_fsm.getRTACode(errCode))("AddCardFromBoxJS req is unhandled ,CurrState=%d", state);
  417. ctx->Answer(Error_Unexpect, errCode);
  418. }
  419. else {
  420. AddCardFromBoxJSEvent* pEvt = new AddCardFromBoxJSEvent();
  421. pEvt->ctx = ctx;
  422. m_fsm.PostEventFIFO(pEvt);
  423. }
  424. }
  425. void MoveAndReadCardFromSlotJS(SpReqAnsContext<CardIssuerStoreService_MoveAndReadCardFromSlotJS_Req, CardIssuerStoreService_MoveAndReadCardFromSlotJS_Ans>::Pointer ctx)
  426. {
  427. LOG_FUNCTION();
  428. if (!m_fsm.GetDevInitFlag()) {
  429. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  430. }
  431. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  432. //不符合请求调用,告知具体错误流程
  433. DWORD errCode = m_fsm.GetFsmStateErrCode();
  434. int state = m_fsm.GetFSMState();
  435. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode(m_fsm.getRTACode(errCode))("MoveAndReadCardFromSlotJS req is unhandled ,CurrState=%d", state);
  436. ctx->Answer(Error_Unexpect, errCode);
  437. }
  438. else {
  439. MoveAndReadCardFromSlotJSEvent* pEvt = new MoveAndReadCardFromSlotJSEvent();
  440. pEvt->ctx = ctx;
  441. m_fsm.PostEventFIFO(pEvt);
  442. }
  443. }
  444. void MoveCardFromSlotJS(SpReqAnsContext<CardIssuerStoreService_MoveCardFromSlotJS_Req, CardIssuerStoreService_MoveCardFromSlotJS_Ans>::Pointer ctx)
  445. {
  446. LOG_FUNCTION();
  447. if (!m_fsm.GetDevInitFlag()) {
  448. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  449. }
  450. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  451. //不符合请求调用,告知具体错误流程
  452. DWORD errCode = m_fsm.GetFsmStateErrCode();
  453. int state = m_fsm.GetFSMState();
  454. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode(m_fsm.getRTACode(errCode))("MoveCardFromSlotJS req is unhandled ,CurrState=%d", state);
  455. ctx->Answer(Error_Unexpect, errCode);
  456. }
  457. else {
  458. MoveCardFromSlotJSEvent* pEvt = new MoveCardFromSlotJSEvent();
  459. pEvt->ctx = ctx;
  460. m_fsm.PostEventFIFO(pEvt);
  461. }
  462. }
  463. void MoveBacktoSlotJS(SpReqAnsContext<CardIssuerStoreService_MoveBacktoSlotJS_Req, CardIssuerStoreService_MoveBacktoSlotJS_Ans>::Pointer ctx)
  464. {
  465. LOG_FUNCTION();
  466. if (!m_fsm.GetDevInitFlag()) {
  467. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  468. }
  469. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  470. //不符合请求调用,告知具体错误流程
  471. DWORD errCode = m_fsm.GetFsmStateErrCode();
  472. int state = m_fsm.GetFSMState();
  473. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode(m_fsm.getRTACode(errCode))("MoveBacktoSlotJS req is unhandled ,CurrState=%d", state);
  474. ctx->Answer(Error_Unexpect, errCode);
  475. }
  476. else {
  477. MoveBacktoSlotJSEvent* pEvt = new MoveBacktoSlotJSEvent();
  478. pEvt->ctx = ctx;
  479. m_fsm.PostEventFIFO(pEvt);
  480. }
  481. }
  482. void QueryHasCardJS(SpReqAnsContext<CardIssuerStoreService_QueryHasCardJS_Req, CardIssuerStoreService_QueryHasCardJS_Ans>::Pointer ctx)
  483. {
  484. LOG_FUNCTION();
  485. if (!m_fsm.GetDevInitFlag()) {
  486. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("QueryHasCardJS but DevOpen failed.");
  487. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  488. }
  489. else {
  490. m_fsm.QueryHasCardJS(ctx);
  491. }
  492. }
  493. void ICCommandJS(SpReqAnsContext<CardIssuerStoreService_ICCommandJS_Req, CardIssuerStoreService_ICCommandJS_Ans>::Pointer ctx)
  494. {
  495. LOG_FUNCTION();
  496. if (!m_fsm.GetDevInitFlag()) {
  497. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  498. }
  499. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  500. //不符合请求调用,告知具体错误流程
  501. DWORD errCode = m_fsm.GetFsmStateErrCode();
  502. int state = m_fsm.GetFSMState();
  503. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode(m_fsm.getRTACode(errCode))("ICCommandJS req is unhandled ,CurrState=%d", state);
  504. ctx->Answer(Error_Unexpect, errCode);
  505. }
  506. else {
  507. ICCommandJSEvent* pEvt = new ICCommandJSEvent();
  508. pEvt->ctx = ctx;
  509. m_fsm.PostEventFIFO(pEvt);
  510. }
  511. }
  512. void WriteTrackJS(SpReqAnsContext<CardIssuerStoreService_WriteTrackJS_Req, CardIssuerStoreService_WriteTrackJS_Ans>::Pointer ctx)
  513. {
  514. LOG_FUNCTION();
  515. if (!m_fsm.GetDevInitFlag()) {
  516. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  517. }
  518. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  519. //不符合请求调用,告知具体错误流程
  520. DWORD errCode = m_fsm.GetFsmStateErrCode();
  521. int state = m_fsm.GetFSMState();
  522. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode(m_fsm.getRTACode(errCode))("WriteTrackJS req is unhandled ,CurrState=%d", state);
  523. ctx->Answer(Error_Unexpect, errCode);
  524. }
  525. else {
  526. WriteTrackJSEvent* pEvt = new WriteTrackJSEvent();
  527. pEvt->ctx = ctx;
  528. m_fsm.PostEventFIFO(pEvt);
  529. }
  530. }
  531. void PrintCardImmediatelyJS(SpReqAnsContext<CardIssuerStoreService_PrintCardImmediatelyJS_Req, CardIssuerStoreService_PrintCardImmediatelyJS_Ans>::Pointer ctx)
  532. {
  533. LOG_FUNCTION();
  534. if (!m_fsm.GetDevInitFlag()) {
  535. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  536. }
  537. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  538. //不符合请求调用,告知具体错误流程
  539. DWORD errCode = m_fsm.GetFsmStateErrCode();
  540. int state = m_fsm.GetFSMState();
  541. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode(m_fsm.getRTACode(errCode))("PrintCardImmediatelyJS req is unhandled ,CurrState=%d", state);
  542. ctx->Answer(Error_Unexpect, errCode);
  543. }
  544. else {
  545. PrintCardImmediatelyJSEvent* pEvt = new PrintCardImmediatelyJSEvent();
  546. pEvt->ctx = ctx;
  547. m_fsm.PostEventFIFO(pEvt);
  548. }
  549. }
  550. void PostOnlineJS(SpReqAnsContext<CardIssuerStoreService_PostOnlineJS_Req, CardIssuerStoreService_PostOnlineJS_Ans>::Pointer ctx)
  551. {
  552. LOG_FUNCTION();
  553. if (!m_fsm.GetDevInitFlag()) {
  554. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  555. }
  556. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  557. //不符合请求调用,告知具体错误流程
  558. DWORD errCode = m_fsm.GetFsmStateErrCode();
  559. int state = m_fsm.GetFSMState();
  560. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode(m_fsm.getRTACode(errCode))("PostOnlineJS req is unhandled ,CurrState=%d", state);
  561. ctx->Answer(Error_Unexpect, errCode);
  562. }
  563. else {
  564. PostOnlineJSEvent* pEvt = new PostOnlineJSEvent();
  565. pEvt->ctx = ctx;
  566. m_fsm.PostEventFIFO(pEvt);
  567. }
  568. }
  569. void IssueFromBoxJS(SpReqAnsContext<CardIssuerStoreService_IssueFromBoxJS_Req, CardIssuerStoreService_IssueFromBoxJS_Ans>::Pointer ctx)
  570. {
  571. LOG_FUNCTION();
  572. if (!m_fsm.GetDevInitFlag()) {
  573. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  574. }
  575. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  576. //不符合请求调用,告知具体错误流程
  577. DWORD errCode = m_fsm.GetFsmStateErrCode();
  578. int state = m_fsm.GetFSMState();
  579. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode(m_fsm.getRTACode(errCode))("IssueFromBoxJS req is unhandled ,CurrState=%d", state);
  580. ctx->Answer(Error_Unexpect, errCode);
  581. }
  582. else {
  583. IssueFromBoxJSEvent* pEvt = new IssueFromBoxJSEvent();
  584. pEvt->ctx = ctx;
  585. m_fsm.PostEventFIFO(pEvt);
  586. }
  587. }
  588. void PreOnlineCrossJS(SpReqAnsContext<CardIssuerStoreService_PreOnlineCrossJS_Req, CardIssuerStoreService_PreOnlineCrossJS_Ans>::Pointer ctx)
  589. {
  590. LOG_FUNCTION();
  591. if (!m_fsm.GetDevInitFlag()) {
  592. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  593. }
  594. else if (_stricmp(m_fsm.GetCurrStateName(), "Failed") == 0) {
  595. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_EntityInFailState);
  596. return;
  597. }
  598. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0 || m_fsm.CheckIsCrossPreOnline()) {
  599. //不符合请求调用,告知具体错误流程
  600. DWORD errCode = m_fsm.GetFsmStateErrCode();
  601. int state = m_fsm.GetFSMState();
  602. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode(m_fsm.getRTACode(errCode))("PreOnlineCrossJS req is unhandled ,CurrState=%d", state);
  603. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_CardActive_CardStore_Issuing);
  604. return;
  605. }
  606. else if (!m_fsm.IsInMainPage()) {
  607. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("PreOnlineCrossJS req is unhandled ,CardissuerStore is busying");
  608. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_CardActive_CardStore_Issuing);
  609. return;
  610. }
  611. else {
  612. PreOnlineCrossJSEvent* pEvt = new PreOnlineCrossJSEvent();
  613. pEvt->ctx = ctx;
  614. m_fsm.PostEventFIFO(pEvt);
  615. }
  616. }
  617. void ReadJS(SpReqAnsContext<CardIssuerStoreService_ReadJS_Req, CardIssuerStoreService_ReadJS_Ans>::Pointer ctx)
  618. {
  619. LOG_FUNCTION();
  620. if (!m_fsm.GetDevInitFlag()) {
  621. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  622. }
  623. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  624. //不符合请求调用,告知具体错误流程
  625. DWORD errCode = m_fsm.GetFsmStateErrCode();
  626. int state = m_fsm.GetFSMState();
  627. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode(m_fsm.getRTACode(errCode))("ReadJS req is unhandled ,CurrState=%d", state);
  628. ctx->Answer(Error_Unexpect, errCode);
  629. }
  630. else {
  631. ReadJSEvent* pEvt = new ReadJSEvent();
  632. pEvt->ctx = ctx;
  633. m_fsm.PostEventFIFO(pEvt);
  634. }
  635. }
  636. virtual void OnSysVarEvent(const char* pszKey, const char* pszValue, const char* pszOldValue, const char* pszEntityName);
  637. virtual bool IsService()const{return true;}
  638. virtual bool IsMultiThread()const{return true;}
  639. protected:
  640. private:
  641. CCardIssuerFSM m_fsm;
  642. bool bInitialized,m_bNewSessionInit;
  643. };