mod_cardissuer.h 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672
  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. 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. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetDevInfo state=%d", ctx->Ans.state);
  295. if (m_fsm.GetDevInitingFlag()) {
  296. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetDevInfo device is opening,state return 0");
  297. ctx->Ans.state = DEVICE_STATUS_NOT_READY;
  298. ctx->Answer(Error_NotInit, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  299. }
  300. else {
  301. //设备未正常打开时,直接报state=0;
  302. if (!m_fsm.GetDevInitFlag()) {
  303. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetDevInfo device is not open,state return 0");
  304. ctx->Ans.state = DEVICE_STATUS_NOT_READY;
  305. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  306. }
  307. else {
  308. ctx->Answer(Error_Succeed);
  309. }
  310. }
  311. }
  312. void QueryCIStatus(SpReqAnsContext<CardIssuerStoreService_QueryCIStatus_Req, CardIssuerStoreService_QueryCIStatus_Ans>::Pointer ctx)
  313. {
  314. m_fsm.QueryCIStatus(ctx);
  315. }
  316. //实体具体接口实现
  317. void EjectJS(SpReqAnsContext<CardIssuerStoreService_EjectJS_Req, CardIssuerStoreService_EjectJS_Ans>::Pointer ctx)
  318. {
  319. LOG_FUNCTION();
  320. if (!m_fsm.GetDevInitFlag()) {
  321. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  322. }
  323. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  324. //不符合请求调用,告知具体错误流程
  325. DWORD errCode = m_fsm.GetFsmStateErrCode();
  326. int state = m_fsm.GetFSMState();
  327. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("EjectJS req is unhandled ,CurrState=%d",state);
  328. ctx->Answer(Error_Unexpect, errCode);
  329. }
  330. else {
  331. EjectJSEvent* e = new EjectJSEvent();
  332. e->ctx = ctx;
  333. m_fsm.PostEventFIFO(e);
  334. }
  335. }
  336. void CaptureJS(SpReqAnsContext<CardIssuerStoreService_CaptureJS_Req, CardIssuerStoreService_CaptureJS_Ans>::Pointer ctx)
  337. {
  338. LOG_FUNCTION();
  339. if (!m_fsm.GetDevInitFlag()) {
  340. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  341. }
  342. else if(_stricmp(m_fsm.GetCurrStateName(), "Hold") == 0 || _stricmp(m_fsm.GetCurrStateName(), "Idle") == 0){
  343. CaptureJSEvent* e = new CaptureJSEvent();
  344. e->ctx = ctx;
  345. m_fsm.PostEventFIFO(e);
  346. }
  347. else {
  348. //不符合请求调用,告知具体错误流程
  349. DWORD errCode = m_fsm.GetFsmStateErrCode();
  350. int state = m_fsm.GetFSMState();
  351. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("CaptureJS req is unhandled ,CurrState=%d", state);
  352. ctx->Answer(Error_Unexpect, errCode);
  353. }
  354. }
  355. void ReadBatchCardInfoInRangeJS(SpReqAnsContext<CardIssuerStoreService_ReadBatchCardInfoInRangeJS_Req, CardIssuerStoreService_ReadBatchCardInfoInRangeJS_Ans>::Pointer ctx)
  356. {
  357. LOG_FUNCTION();
  358. if (!m_fsm.GetDevInitFlag()) {
  359. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  360. }
  361. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  362. //不符合请求调用,告知具体错误流程
  363. DWORD errCode = m_fsm.GetFsmStateErrCode();
  364. int state = m_fsm.GetFSMState();
  365. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("ReadBatchCardInfoInRangeJS req is unhandled ,CurrState=%d", state);
  366. ctx->Answer(Error_Unexpect, errCode);
  367. }
  368. else {
  369. ReadBatchCardInfoInRangeJSEvent* pEvt = new ReadBatchCardInfoInRangeJSEvent();
  370. pEvt->ctx = ctx;
  371. m_fsm.PostEventFIFO(pEvt);
  372. }
  373. }
  374. void GetCardInStoreJS(SpReqAnsContext<CardIssuerStoreService_GetCardInStoreJS_Req, CardIssuerStoreService_GetCardInStoreJS_Ans>::Pointer ctx)
  375. {
  376. LOG_FUNCTION();
  377. if (!m_fsm.GetDevInitFlag()) {
  378. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  379. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("GetCardInStoreJS but DevOpen failed.");
  380. }
  381. else {
  382. m_fsm.GetCardInStoreJS(ctx);
  383. }
  384. }
  385. void AddAndReadCardFromBoxJS(SpReqAnsContext<CardIssuerStoreService_AddAndReadCardFromBoxJS_Req, CardIssuerStoreService_AddAndReadCardFromBoxJS_Ans>::Pointer ctx)
  386. {
  387. LOG_FUNCTION();
  388. if (!m_fsm.GetDevInitFlag()) {
  389. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  390. }
  391. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  392. //不符合请求调用,告知具体错误流程
  393. DWORD errCode = m_fsm.GetFsmStateErrCode();
  394. int state = m_fsm.GetFSMState();
  395. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("AddAndReadCardFromBoxJS req is unhandled ,CurrState=%d", state);
  396. ctx->Answer(Error_Unexpect, errCode);
  397. }
  398. else {
  399. AddAndReadCardFromBoxJSEvent* pEvt = new AddAndReadCardFromBoxJSEvent();
  400. pEvt->ctx = ctx;
  401. m_fsm.PostEventFIFO(pEvt);
  402. }
  403. }
  404. void AddCardFromBoxJS(SpReqAnsContext<CardIssuerStoreService_AddCardFromBoxJS_Req, CardIssuerStoreService_AddCardFromBoxJS_Ans>::Pointer ctx)
  405. {
  406. LOG_FUNCTION();
  407. if (!m_fsm.GetDevInitFlag()) {
  408. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  409. }
  410. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  411. //不符合请求调用,告知具体错误流程
  412. DWORD errCode = m_fsm.GetFsmStateErrCode();
  413. int state = m_fsm.GetFSMState();
  414. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("AddCardFromBoxJS req is unhandled ,CurrState=%d", state);
  415. ctx->Answer(Error_Unexpect, errCode);
  416. }
  417. else {
  418. AddCardFromBoxJSEvent* pEvt = new AddCardFromBoxJSEvent();
  419. pEvt->ctx = ctx;
  420. m_fsm.PostEventFIFO(pEvt);
  421. }
  422. }
  423. void MoveAndReadCardFromSlotJS(SpReqAnsContext<CardIssuerStoreService_MoveAndReadCardFromSlotJS_Req, CardIssuerStoreService_MoveAndReadCardFromSlotJS_Ans>::Pointer ctx)
  424. {
  425. LOG_FUNCTION();
  426. if (!m_fsm.GetDevInitFlag()) {
  427. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  428. }
  429. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  430. //不符合请求调用,告知具体错误流程
  431. DWORD errCode = m_fsm.GetFsmStateErrCode();
  432. int state = m_fsm.GetFSMState();
  433. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("MoveAndReadCardFromSlotJS req is unhandled ,CurrState=%d", state);
  434. ctx->Answer(Error_Unexpect, errCode);
  435. }
  436. else {
  437. MoveAndReadCardFromSlotJSEvent* pEvt = new MoveAndReadCardFromSlotJSEvent();
  438. pEvt->ctx = ctx;
  439. m_fsm.PostEventFIFO(pEvt);
  440. }
  441. }
  442. void MoveCardFromSlotJS(SpReqAnsContext<CardIssuerStoreService_MoveCardFromSlotJS_Req, CardIssuerStoreService_MoveCardFromSlotJS_Ans>::Pointer ctx)
  443. {
  444. LOG_FUNCTION();
  445. if (!m_fsm.GetDevInitFlag()) {
  446. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  447. }
  448. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  449. //不符合请求调用,告知具体错误流程
  450. DWORD errCode = m_fsm.GetFsmStateErrCode();
  451. int state = m_fsm.GetFSMState();
  452. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("MoveCardFromSlotJS req is unhandled ,CurrState=%d", state);
  453. ctx->Answer(Error_Unexpect, errCode);
  454. }
  455. else {
  456. MoveCardFromSlotJSEvent* pEvt = new MoveCardFromSlotJSEvent();
  457. pEvt->ctx = ctx;
  458. m_fsm.PostEventFIFO(pEvt);
  459. }
  460. }
  461. void MoveBacktoSlotJS(SpReqAnsContext<CardIssuerStoreService_MoveBacktoSlotJS_Req, CardIssuerStoreService_MoveBacktoSlotJS_Ans>::Pointer ctx)
  462. {
  463. LOG_FUNCTION();
  464. if (!m_fsm.GetDevInitFlag()) {
  465. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  466. }
  467. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  468. //不符合请求调用,告知具体错误流程
  469. DWORD errCode = m_fsm.GetFsmStateErrCode();
  470. int state = m_fsm.GetFSMState();
  471. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("MoveBacktoSlotJS req is unhandled ,CurrState=%d", state);
  472. ctx->Answer(Error_Unexpect, errCode);
  473. }
  474. else {
  475. MoveBacktoSlotJSEvent* pEvt = new MoveBacktoSlotJSEvent();
  476. pEvt->ctx = ctx;
  477. m_fsm.PostEventFIFO(pEvt);
  478. }
  479. }
  480. void QueryHasCardJS(SpReqAnsContext<CardIssuerStoreService_QueryHasCardJS_Req, CardIssuerStoreService_QueryHasCardJS_Ans>::Pointer ctx)
  481. {
  482. LOG_FUNCTION();
  483. if (!m_fsm.GetDevInitFlag()) {
  484. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("QueryHasCardJS but DevOpen failed.");
  485. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  486. }
  487. else {
  488. m_fsm.QueryHasCardJS(ctx);
  489. }
  490. }
  491. void ICCommandJS(SpReqAnsContext<CardIssuerStoreService_ICCommandJS_Req, CardIssuerStoreService_ICCommandJS_Ans>::Pointer ctx)
  492. {
  493. LOG_FUNCTION();
  494. if (!m_fsm.GetDevInitFlag()) {
  495. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  496. }
  497. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  498. //不符合请求调用,告知具体错误流程
  499. DWORD errCode = m_fsm.GetFsmStateErrCode();
  500. int state = m_fsm.GetFSMState();
  501. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("ICCommandJS req is unhandled ,CurrState=%d", state);
  502. ctx->Answer(Error_Unexpect, errCode);
  503. }
  504. else {
  505. ICCommandJSEvent* pEvt = new ICCommandJSEvent();
  506. pEvt->ctx = ctx;
  507. m_fsm.PostEventFIFO(pEvt);
  508. }
  509. }
  510. void WriteTrackJS(SpReqAnsContext<CardIssuerStoreService_WriteTrackJS_Req, CardIssuerStoreService_WriteTrackJS_Ans>::Pointer ctx)
  511. {
  512. LOG_FUNCTION();
  513. if (!m_fsm.GetDevInitFlag()) {
  514. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  515. }
  516. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  517. //不符合请求调用,告知具体错误流程
  518. DWORD errCode = m_fsm.GetFsmStateErrCode();
  519. int state = m_fsm.GetFSMState();
  520. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("WriteTrackJS req is unhandled ,CurrState=%d", state);
  521. ctx->Answer(Error_Unexpect, errCode);
  522. }
  523. else {
  524. WriteTrackJSEvent* pEvt = new WriteTrackJSEvent();
  525. pEvt->ctx = ctx;
  526. m_fsm.PostEventFIFO(pEvt);
  527. }
  528. }
  529. void PrintCardImmediatelyJS(SpReqAnsContext<CardIssuerStoreService_PrintCardImmediatelyJS_Req, CardIssuerStoreService_PrintCardImmediatelyJS_Ans>::Pointer ctx)
  530. {
  531. LOG_FUNCTION();
  532. if (!m_fsm.GetDevInitFlag()) {
  533. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  534. }
  535. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  536. //不符合请求调用,告知具体错误流程
  537. DWORD errCode = m_fsm.GetFsmStateErrCode();
  538. int state = m_fsm.GetFSMState();
  539. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("PrintCardImmediatelyJS req is unhandled ,CurrState=%d", state);
  540. ctx->Answer(Error_Unexpect, errCode);
  541. }
  542. else {
  543. PrintCardImmediatelyJSEvent* pEvt = new PrintCardImmediatelyJSEvent();
  544. pEvt->ctx = ctx;
  545. m_fsm.PostEventFIFO(pEvt);
  546. }
  547. }
  548. void PostOnlineJS(SpReqAnsContext<CardIssuerStoreService_PostOnlineJS_Req, CardIssuerStoreService_PostOnlineJS_Ans>::Pointer ctx)
  549. {
  550. LOG_FUNCTION();
  551. if (!m_fsm.GetDevInitFlag()) {
  552. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  553. }
  554. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  555. //不符合请求调用,告知具体错误流程
  556. DWORD errCode = m_fsm.GetFsmStateErrCode();
  557. int state = m_fsm.GetFSMState();
  558. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("PostOnlineJS req is unhandled ,CurrState=%d", state);
  559. ctx->Answer(Error_Unexpect, errCode);
  560. }
  561. else {
  562. PostOnlineJSEvent* pEvt = new PostOnlineJSEvent();
  563. pEvt->ctx = ctx;
  564. m_fsm.PostEventFIFO(pEvt);
  565. }
  566. }
  567. void IssueFromBoxJS(SpReqAnsContext<CardIssuerStoreService_IssueFromBoxJS_Req, CardIssuerStoreService_IssueFromBoxJS_Ans>::Pointer ctx)
  568. {
  569. LOG_FUNCTION();
  570. if (!m_fsm.GetDevInitFlag()) {
  571. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  572. }
  573. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0) {
  574. //不符合请求调用,告知具体错误流程
  575. DWORD errCode = m_fsm.GetFsmStateErrCode();
  576. int state = m_fsm.GetFSMState();
  577. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("IssueFromBoxJS req is unhandled ,CurrState=%d", state);
  578. ctx->Answer(Error_Unexpect, errCode);
  579. }
  580. else {
  581. IssueFromBoxJSEvent* pEvt = new IssueFromBoxJSEvent();
  582. pEvt->ctx = ctx;
  583. m_fsm.PostEventFIFO(pEvt);
  584. }
  585. }
  586. void PreOnlineCrossJS(SpReqAnsContext<CardIssuerStoreService_PreOnlineCrossJS_Req, CardIssuerStoreService_PreOnlineCrossJS_Ans>::Pointer ctx)
  587. {
  588. LOG_FUNCTION();
  589. if (!m_fsm.GetDevInitFlag()) {
  590. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  591. }
  592. else if (_stricmp(m_fsm.GetCurrStateName(), "Failed") == 0) {
  593. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_EntityInFailState);
  594. return;
  595. }
  596. else if (_stricmp(m_fsm.GetCurrStateName(), "Idle") != 0 || m_fsm.CheckIsCrossPreOnline()) {
  597. //不符合请求调用,告知具体错误流程
  598. DWORD errCode = m_fsm.GetFsmStateErrCode();
  599. int state = m_fsm.GetFSMState();
  600. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("PreOnlineCrossJS req is unhandled ,CurrState=%d", state);
  601. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_CardActive_CardStore_Issuing);
  602. return;
  603. }
  604. else if (!m_fsm.IsInMainPage()) {
  605. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("PreOnlineCrossJS req is unhandled ,CardissuerStore is busying");
  606. ctx->Answer(Error_InvalidState, CardIssuerStore_UserErrorCode_CardActive_CardStore_Issuing);
  607. return;
  608. }
  609. else {
  610. PreOnlineCrossJSEvent* pEvt = new PreOnlineCrossJSEvent();
  611. pEvt->ctx = ctx;
  612. m_fsm.PostEventFIFO(pEvt);
  613. }
  614. }
  615. void ReadJS(SpReqAnsContext<CardIssuerStoreService_ReadJS_Req, CardIssuerStoreService_ReadJS_Ans>::Pointer ctx)
  616. {
  617. LOG_FUNCTION();
  618. if (!m_fsm.GetDevInitFlag()) {
  619. ctx->Answer(Error_DevNotAvailable, CardIssuerStore_UserErrorCode_DevOpen_Failed);
  620. }
  621. else if (_stricmp(m_fsm.GetCurrStateName(), "Hold") != 0) {
  622. //不符合请求调用,告知具体错误流程
  623. DWORD errCode = m_fsm.GetFsmStateErrCode();
  624. int state = m_fsm.GetFSMState();
  625. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("ReadJS req is unhandled ,CurrState=%d", state);
  626. ctx->Answer(Error_Unexpect, errCode);
  627. }
  628. else {
  629. ReadJSEvent* pEvt = new ReadJSEvent();
  630. pEvt->ctx = ctx;
  631. m_fsm.PostEventFIFO(pEvt);
  632. }
  633. }
  634. virtual void OnSysVarEvent(const char* pszKey, const char* pszValue, const char* pszOldValue, const char* pszEntityName);
  635. virtual bool IsService()const{return true;}
  636. virtual bool IsMultiThread()const{return true;}
  637. protected:
  638. private:
  639. CCardIssuerFSM m_fsm;
  640. bool bInitialized,m_bNewSessionInit;
  641. };