123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754 |
- #include "stdafx.h"
- #include "SpBase.h"
- #include "SpHelper.h"
- #include "CardReadAdapterFSM.h"
- #include "EventCode.h"
- #include <algorithm>
- #include <map>
- using namespace std;
- #define _ATL_NO_AUTOMATIC_NAMESPACE
- #define ReadCard_TIMEOUT 62000 //web的超时时间是65s
- #define ReadCard_Min_Time 12000 //Read+PreOnline
- //TODO: CrossPlaform [Gifur@2025730]
- unsigned long long GetTickCountRVC() {
- #ifdef RVC_OS_WIN
- return GetTickCount64();
- #else
- struct timespec ts;
- clock_gettime(CLOCK_MONOTONIC, &ts);
- return (ts.tv_sec * 1000 + ts.tv_nsec / 1000000);
- #endif //RVC_OS_WIN
- }
- class CCardReadAdapterEntity;
- void CCardReadAdapterFSM::s0_on_entry()
- {
- LOG_FUNCTION();
- CSystemStaticInfo sysInfo;
- m_csMachineType = m_terminalNo = "";
- GetEntityBase()->GetFunction()->GetSystemStaticInfo(sysInfo);
- m_csMachineType = sysInfo.strMachineType;
- m_terminalNo = sysInfo.strTerminalID;
- m_eMachineType = SpStr2MachineType(sysInfo.strMachineType);
- /** test [Gifur@202587]*/
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("machinType:%d", m_eMachineType);
- m_csMachineType = "";
- GetEntityBase()->GetFunction()->GetMachineType(&m_csMachineType);
- /** test done [Gifur@202587]*/
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("machineType:%s,terminalNo:%s", (const char*)m_csMachineType, (const char*)m_terminalNo);
- FSMEvent *pEvt;
- pEvt = new FSMEvent(USER_EVT_INIT);
- PostEventFIFO(pEvt);
- }
- void CCardReadAdapterFSM::s0_on_exit()
- {
- LOG_FUNCTION();
- }
- unsigned int CCardReadAdapterFSM::s0_on_event(FSMEvent* pEvt)
- {
- LOG_FUNCTION();
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s0 evt %d", pEvt->iEvt);
- switch (pEvt->iEvt)
- {
- case USER_EVT_INIT:
- {
- InitTask* task = new InitTask(this);
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- pEvt->SetHandled();
- return 0;
- }
- break;
- default:
- break;
- }
- return 0;
- }
- //Initializing
- void CCardReadAdapterFSM::s1_on_entry()
- {
- LOG_FUNCTION();
- }
- void CCardReadAdapterFSM::s1_on_exit()
- {
- LOG_FUNCTION();
- }
- unsigned int CCardReadAdapterFSM::s1_on_event(FSMEvent* pEvt)
- {
- LOG_FUNCTION();
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s1 evt %d", pEvt->iEvt);
- switch (pEvt->iEvt)
- {
- case USER_EVT_INIT_FINISHED:
- pEvt->SetHandled();
- return pEvt->param1;
- default:
- break;
- }
- return 0;
- }
- //Idle
- void CCardReadAdapterFSM::s2_on_entry()
- {
- LOG_FUNCTION();
- //GetEntityBase()->GetFunction()->SetUserDefineState(USER_CARDISSUER_IDLE);
- m_resetTimes = 0;
- m_testResult = Error_Succeed;
- m_bIssuingExit = false;
- m_bCancelAccept = false;
- m_lastS2Event = m_lastS2EvtParam1 = 0;
- m_busCtx.eCardProcStage = Card_ProcStage_Idle;
- }
- void CCardReadAdapterFSM::s2_on_exit()
- {
- LOG_FUNCTION();
- }
- unsigned int CCardReadAdapterFSM::s2_on_event(FSMEvent* pEvt)
- {
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s2 evt(%d),param1:%d", pEvt->iEvt,pEvt->param1);
- m_lastS2Event = pEvt->iEvt;
- m_lastS2EvtParam1 = pEvt->param1;
- int ret = 0;
- switch (pEvt->iEvt)
- {
- case USER_EVT_READ:
- {
- //oilyang@20200426 according to MachineType ***AND MachineVersion*** to decide which Card-like entity to be called
- //RVC.Stand2S, RVC.CardStore
- // ContactlessCard:
- // --RVC.Stand2S
- // CardIssuerStand or CardIssuerStore:
- // --no matter what MachineType is,just call it
- pEvt->SetHandled();
- CardReadEvent* cre = dynamic_cast<CardReadEvent*>(pEvt);
- bool bCardIssuer, bContactlessCard;
- bCardIssuer = bContactlessCard = false;
- if (m_eMachineType == RVC_Stand2S || m_eMachineType == RVC_Stand1SPlus)
- {
- ContactlessCardReadTask* cTask = new ContactlessCardReadTask(this);
- cTask->ctx = cre->ctx;
- if (IsTheEntity(cre->ctx->Req.module, Module_ContactlessCard) && IsContactlessCardSessionOK())
- {
- bContactlessCard = true;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(cTask);
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_USER)("ReadTask to ContactlessCard");
- }
- }
- //oilyang@20200426 暂时未发现这行代码的用处,可能简版?后来废弃。暂时保留,后续考虑去掉
- if ((cre->ctx->Req.reserved1.GetCount() == 0 || cre->ctx->Req.reserved1[0] != 1))//except for cross call
- {
- CardIssuerReadTask* iTask = new CardIssuerReadTask(this);
- iTask->ctx = cre->ctx;
- if (IsTheEntity(cre->ctx->Req.module, Module_CardIssuer) && IsCardIssuerSessionOK())
- {
- bCardIssuer = true;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(iTask);
- }
- if (bCardIssuer || bContactlessCard)
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("ReadTask, bCardIssuer,bContactlessCard:%d,%d", bCardIssuer, bContactlessCard);
- else
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("ReadTask: can't find the right entity.");
- ret = 1;//no need to change to "Working" state
- cre->ctx->Answer(Error_Unexpect);
- }
- }
- }
- break;
- case USER_EVT_PREONLINE:
- {
- PreOnlineEvent* poe = dynamic_cast<PreOnlineEvent*>(pEvt);
- PreOnlineTask* task = new PreOnlineTask(this);
- task->ctx = poe->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- pEvt->SetHandled();
- return 0;
- }
- case USER_EVT_WRITE:
- {
- pEvt->SetHandled();
- CardWriteEvent* cwe = dynamic_cast<CardWriteEvent*>(pEvt);
- WriteTask* task = new WriteTask(this);
- task->ctx = cwe->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- return 0;
- }
- case USER_EVT_POSTONLINE:
- {
- PostOnlineEvent* poe = dynamic_cast<PostOnlineEvent*>(pEvt);
- PostOnlineTask* task = new PostOnlineTask(this);
- task->ctx = poe->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- pEvt->SetHandled();
- return 0;
- }
- case USER_EVT_EXIT:
- {
- m_busCtx.eCardFromWhich = Card_In_No_Where;
- pEvt->SetHandled();
- DoExitTask* task = new DoExitTask(this);
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_EJECT:
- {
- pEvt->SetHandled();
- CardEjectEvent* cee = dynamic_cast<CardEjectEvent*>(pEvt);
- EjectTask* task = new EjectTask(this);
- task->ctx = cee->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_SET_SOME_FLAG:
- {
- pEvt->SetHandled();
- SetSomeFlagEvent* ssfe = dynamic_cast<SetSomeFlagEvent*>(pEvt);
- SetSomeFlagTask* task = new SetSomeFlagTask(this);
- task->ctx = ssfe->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_GET_DEV_INFO:
- {
- pEvt->SetHandled();
- GetDevInfoEvent* gdie = dynamic_cast<GetDevInfoEvent*>(pEvt);
- GetDevInfoTask* task = new GetDevInfoTask(this);
- task->ctx = gdie->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_QUERY_CARD_INFO:
- {
- pEvt->SetHandled();
- QueryCardInfoEvent* qcie = dynamic_cast<QueryCardInfoEvent*>(pEvt);
- QueryCardInfoTask* task = new QueryCardInfoTask(this);
- task->ctx = qcie->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_QUIT:
- pEvt->SetHandled();
- break;
- case USER_EVT_ISSUE:
- {
- pEvt->SetHandled();
- CardIssueEvent* cee = dynamic_cast<CardIssueEvent*>(pEvt);
- IssueTask* task = new IssueTask(this);
- task->ctx = cee->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_CAPTURE:
- {
- pEvt->SetHandled();
- CardCaptureEvent* cee = dynamic_cast<CardCaptureEvent*>(pEvt);
- CaptureTask* task = new CaptureTask(this);
- task->ctx = cee->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_GET_MATERIAL:
- {
- pEvt->SetHandled();
- GetMaterialEvent *gme = dynamic_cast<GetMaterialEvent*>(pEvt);
- GetMaterialCountTask *task = new GetMaterialCountTask(this);
- task->ctx = gme->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- break;
- }
- case USER_EVT_SET_MATERIAL:
- {
- pEvt->SetHandled();
- SetMaterialEvent *sme = dynamic_cast<SetMaterialEvent*>(pEvt);
- SetMaterialCountTask *task = new SetMaterialCountTask(this);
- task->ctx = sme->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- break;
- }
- case USER_EVT_OPEN_SAFELOCK:
- {
- pEvt->SetHandled();
- OpenSafeLockEvent *osle = dynamic_cast<OpenSafeLockEvent*>(pEvt);
- OpenSafeLockTask* task = new OpenSafeLockTask(this);
- task->ctx = osle->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_MAGTRANS_INIT:
- {
- pEvt->SetHandled();
- MagTransferInitEvent* mtie = dynamic_cast<MagTransferInitEvent*>(pEvt);
- MagTransferInitTask* task = new MagTransferInitTask(this);
- task->ctx = mtie->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_QUERY_CONN_INFO:
- {
- pEvt->SetHandled();
- QueryConnInfoEvent* qcie = dynamic_cast<QueryConnInfoEvent*>(pEvt);
- QueryConnInfoTask* task = new QueryConnInfoTask(this);
- task->ctx = qcie->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_SAM_IC_COMMAND:
- {
- pEvt->SetHandled();
- SAMICCommandEvent* samice = dynamic_cast<SAMICCommandEvent*>(pEvt);
- SAMICCommandTask* task = new SAMICCommandTask(this);
- task->ctx = samice->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_QUERY_PRINTER_STATUS:
- {
- pEvt->SetHandled();
- QueryPrinterStatusEvent* samice = dynamic_cast<QueryPrinterStatusEvent*>(pEvt);
- QueryPrinterStatusTask* task = new QueryPrinterStatusTask(this);
- task->ctx = samice->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_PRINT:
- {
- pEvt->SetHandled();
- PrintEvent* samice = dynamic_cast<PrintEvent*>(pEvt);
- PrintTask* task = new PrintTask(this);
- task->ctx = samice->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_QUERY_SCILIST:
- {
- pEvt->SetHandled();
- QuerySCIListEvent* samice = dynamic_cast<QuerySCIListEvent*>(pEvt);
- QuerySCIListTask* task = new QuerySCIListTask(this);
- task->ctx = samice->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_BIND_SCI:
- {
- pEvt->SetHandled();
- BindSCIEvent* samice = dynamic_cast<BindSCIEvent*>(pEvt);
- BindSCITask* task = new BindSCITask(this);
- task->ctx = samice->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_PREONLINE_ON_STORE:
- {
- pEvt->SetHandled();
- PreOnlineOnStoreEvent* samice = dynamic_cast<PreOnlineOnStoreEvent*>(pEvt);
- PreOnlineOnStoreTask* task = new PreOnlineOnStoreTask(this);
- task->ctx = samice->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_GET_ADD_CARD_INFO:
- {
- pEvt->SetHandled();
- GetAddCardInfoEvent* samice = dynamic_cast<GetAddCardInfoEvent*>(pEvt);
- GetAddCardInfoTask* task = new GetAddCardInfoTask(this);
- task->ctx = samice->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_QUERY_CARD_INFO_ON_STORE:
- {
- pEvt->SetHandled();
- QueryCardInfoOnStoreEvent* samice = dynamic_cast<QueryCardInfoOnStoreEvent*>(pEvt);
- QueryCardInfoOnStoreTask* task = new QueryCardInfoOnStoreTask(this);
- task->ctx = samice->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_CROSS_TERM_CALL:
- {
- pEvt->SetHandled();
- CrossTermCallEvent* ctce = dynamic_cast<CrossTermCallEvent*>(pEvt);
- CrossTermCallTask* task = new CrossTermCallTask(this);
- task->ctx = ctce->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_PRINT_CARD_IM:
- {
- pEvt->SetHandled();
- PrintCardImEvent* pcie = dynamic_cast<PrintCardImEvent*>(pEvt);
- PrintCardImTask* task = new PrintCardImTask(this);
- task->ctx = pcie->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_QUERY_CI_STATUS:
- {
- pEvt->SetHandled();
- QueryCIStatusEvent* qcse = dynamic_cast<QueryCIStatusEvent*>(pEvt);
- QueryCIStatusTask* task = new QueryCIStatusTask(this);
- task->ctx = qcse->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- default:
- break;
- }
- return ret;
- }
- //Working
- void CCardReadAdapterFSM::s3_on_entry()
- {
- LOG_FUNCTION();
- }
- void CCardReadAdapterFSM::s3_on_exit()
- {
- LOG_FUNCTION();
- }
- unsigned int CCardReadAdapterFSM::s3_on_event(FSMEvent* pEvt)
- {
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s3 evt %d,%d", pEvt->iEvt,pEvt->param1);
- int ret = 0;
- switch (pEvt->iEvt)
- {
- case USER_EVT_NOTIFY_PREONLINE:
- {
- pEvt->SetHandled();
- NotifyPreonlineEvent* samice = dynamic_cast<NotifyPreonlineEvent*>(pEvt);
- NotifyPreOnlineTask* task = new NotifyPreOnlineTask(this);
- task->ctx = samice->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_READ_FINISHED:
- {
- pEvt->SetHandled();
- ret = pEvt->param1;
- //if (pEvt->param1 == 0)
- CardReadFinishedEvent* crfe = dynamic_cast<CardReadFinishedEvent*>(pEvt);
- {
- if (m_bCancelAccept)
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("front cancel");
- crfe->ctx->Answer(Error_Cancel);
- ret = 0;
- }
- }
- if (pEvt->param1 == 7)//CardIssuerStand or CardIssuerStore Timeout,need to cancel ContactlessCard insert
- {
- if (!IsCardIssuerStore()) {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("CardIssuerStand Timeout,need to cancel ContactlessCard insert");
- }
- else {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("CardIssuerStore Timeout,need to cancel ContactlessCard insert");
- }
- if (IsContactlessCardSessionOK())
- (*m_pContactless)(EntityResource::getLink().upgradeLink())->CancelInsert();
- crfe->ctx->Answer(Error_TimeOut);
- ret = 0;
- break;
- }
- else if (pEvt->param1 == 8)//ContactlessCard Timeout,need to cancel CardIssuerStand or CardIssuerStore insert
- {
-
- if (IsCardIssuerSessionOK()) {
- if (!IsCardIssuerStore()) {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ContactlessCard Timeout,need to cancel CardIssuerStand insert");
- (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->CancelInsert();
- }
- else {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ContactlessCard Timeout,need to cancel CardIssuerStore insert");
- (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->CancelInsert();
- }
- }
-
- crfe->ctx->Answer(Error_TimeOut);
- ret = 0;
- break;
- }
- else if (pEvt->param1 == 9)//ContactlessCard Timeout,need to cancel ContactlessCard insert
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("need to cancel ContactlessCard insert");
- if (IsContactlessCardSessionOK())
- (*m_pContactless)(EntityResource::getLink().upgradeLink())->CancelInsert();
- crfe->ctx->Answer(Error_TimeOut);
- ret = 0;
- break;
- }
- if (m_busCtx.eCardFromWhich == Card_In_ContactlessCard)
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("as card in ContactlessCard,to cancel others");
- if (IsCardIssuerSessionOK()) {
- if (!IsCardIssuerStore()) {
- (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->CancelInsert();
- }
- else {
- (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->CancelInsert();
- }
- }
- }
- else if (m_busCtx.eCardFromWhich == Card_In_CardIssuer)
- {
- //在读卡时已发送了非接取消读卡请求,此处不再重复发送
- //if (!IsCardIssuerStore()) {
- // DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("as card in CardIssuerStand,to cancel others");
- //}
- //else {
- // DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("as card in CardIssuerStore,to cancel others");
- //}
- //if (IsContactlessCardSessionOK())
- // (*m_pContactless)(EntityResource::getLink().upgradeLink())->CancelInsert();
- }
- return ret;
- }
- case USER_EVT_PREONLINE_FINISHED:
- pEvt->SetHandled();
- return 0;
- case USER_EVT_POSTONLINE_FINISHED:
- pEvt->SetHandled();
- return 0;
- case USER_EVT_READ_CANCEL:
- pEvt->SetHandled();
- m_bCancelAccept = true;
- CancelRead();
- break;
- case USER_EVT_READ_WAIT_MORE:
- {
- pEvt->SetHandled();
- ReadWaitMoreTask* task = new ReadWaitMoreTask(this);
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_EXIT:
- {
- m_busCtx.eCardFromWhich = Card_In_No_Where;
- pEvt->SetHandled();
- DoExitTask* task = new DoExitTask(this);
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_WRITE_FINISHED:
- case USER_EVT_SET_SOME_FLAG_FINISHED:
- case USER_EVT_GET_DEV_INFO_FINISHED:
- case USER_EVT_QUERY_CARD_INFO_FINISHED:
- case USER_EVT_GET_MATERIAL_FINISHED:
- case USER_EVT_SET_MATERIAL_FINISHED:
- case USER_EVT_GET_SCI_INFO_FINISHED:
- case USER_EVT_OPEN_SAFELOCK_FINISHED:
- case USER_EVT_MAGTRANS_INIT_FINISHED:
- case USER_EVT_QUERY_CONN_INFO_FINISHED:
- case USER_EVT_QUIT:
- case USER_EVT_SAM_IC_COMMAND_FINISHED:
- case USER_EVT_QUERY_PRINTER_STATUS_FINISHED:
- case USER_EVT_PRINT_FINISHED:
- case USER_EVT_QUERY_SCILIST_FINISHED:
- case USER_EVT_BIND_SCI_FINISHED:
- case USER_EVT_PREONLINE_ON_STORE_FINISHED:
- case USER_EVT_GET_ADD_CARD_INFO_FINISHED:
- case USER_EVT_NOTIFY_PREONLINE_FINISHED:
- case USER_EVT_QUERY_CARD_INFO_ON_STORE_FINISHED:
- case USER_EVT_CROSS_TERM_CALL_FINISHED:
- case USER_EVT_PRINT_CARD_IM_FINISHED:
- case USER_EVT_QUERY_CI_STATUS_FINISHED:
- case USER_EVT_EJECT_FINISHED:
- pEvt->SetHandled();
- break;
- default:
- break;
- }
- return ret;
- }
- //Failed
- void CCardReadAdapterFSM::s4_on_entry()
- {
- LOG_FUNCTION();
- m_lastS2Event = m_lastS2EvtParam1 = 0;
- //GetEntityBase()->GetFunction()->SetUserDefineState(USER_CARDISSUER_HOLD);
- }
- void CCardReadAdapterFSM::s4_on_exit()
- {
- LOG_FUNCTION();
- }
- unsigned int CCardReadAdapterFSM::s4_on_event(FSMEvent* pEvt)
- {
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s4 evt(%d)", pEvt->iEvt);
- switch (pEvt->iEvt)
- {
- case USER_EVT_EXIT:
- {
- pEvt->SetHandled();
- DoExitTask* task = new DoExitTask(this);
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_QUIT:
- {
- pEvt->SetHandled();
- return 0;
- }
- case USER_EVT_SET_SOME_FLAG:
- {
- pEvt->SetHandled();
- SetSomeFlagEvent* ssfe = dynamic_cast<SetSomeFlagEvent*>(pEvt);
- SetSomeFlagTask* task = new SetSomeFlagTask(this);
- task->ctx = ssfe->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_GET_DEV_INFO:
- {
- pEvt->SetHandled();
- GetDevInfoEvent* gdie = dynamic_cast<GetDevInfoEvent*>(pEvt);
- GetDevInfoTask* task = new GetDevInfoTask(this);
- task->ctx = gdie->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- case USER_EVT_QUERY_CARD_INFO:
- {
- pEvt->SetHandled();
- QueryCardInfoEvent* qcie = dynamic_cast<QueryCardInfoEvent*>(pEvt);
- QueryCardInfoTask* task = new QueryCardInfoTask(this);
- task->ctx = qcie->ctx;
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- }
- break;
- default:
- break;
- }
- return 0;
- }
- ErrorCodeEnum CCardReadAdapterFSM::OnInit()
- {
- LOG_FUNCTION();
- m_lastS2Event = m_lastS2EvtParam1 = 0;
- m_busCtx.eCardFromWhich = Card_In_No_Where;
- return Error_Succeed;
- }
- ErrorCodeEnum CCardReadAdapterFSM::OnExit()
- {
- LOG_FUNCTION();
- FSMImpl<CCardReadAdapterFSM>::OnExit();
- return Error_Succeed;
- }
- int CCardReadAdapterFSM::Initial()
- {
- CheckSessionTask *pTask = new CheckSessionTask(this);
- GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
- ErrorCodeEnum eErr;
- eErr = GetEntityBase()->GetFunction()->SetSysVar("CardEntityState", "E");
- if (eErr != Error_Succeed)
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("SetSysVar CardEntityState failed.%d",eErr);
- }
- return 0;//oiltmp no need to connect. let function "CheckAndReconnectSession" do
- }
- int CCardReadAdapterFSM::DoWork(int type)
- {
- switch (type)
- {
- case USER_EVT_READ:
- {
- }
- break;
- default:
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("unkown type:%d",type);
- break;
- }
- return 0;
- }
- int CCardReadAdapterFSM::CardIssuerRead(SpReqAnsContext<CardReadAdapterService_Read_Req, CardReadAdapterService_Read_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- if (m_bCancelAccept || (m_busCtx.eCardFromWhich == Card_In_ContactlessCard))
- {
- char msg[128];
- memset(msg, 0, 128);
- sprintf(msg, "Maybe the thread pool is wrong.CardIssuerRead,bCancel:%d,cardpos:%d", m_bCancelAccept, m_busCtx.eCardFromWhich);
- LogWarn(Severity_Middle, Error_NotInit, CardReadAdapter_UserErrorCode_MayBe_ThreadPool_Wrong, msg);
- return 3;
- }
- ErrorCodeEnum eErr = Error_Unexpect;
- if (IsTheEntity(ctx->Req.module,Module_CardIssuer) && IsCardIssuerSessionOK())
- {
- if (!IsCardIssuerStore()) {
- CardIssuerStandService_QueryCardInfo_Req qciReq;
- CardIssuerStandService_QueryCardInfo_Ans qciAns;
- bool bHasCard = false, bNeedPreOnline = false, bCardMismatch = false;
- DWORD dwUsrErrCode = 0;
- CSimpleStringA csRetStr(true);
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->QueryCardInfo(qciReq, qciAns, 10000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- if (qciAns.position == 2)//有卡
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("CardIssuerStand has card, cancel ContactlessCard.");
- bHasCard = true;
- //oilyang@20220817 为什么要给默认值?Read失败,没有必要PreOnline
- //bNeedPreOnline = true;//不知道卡片类型,默认
- m_busCtx.eCardFromWhich = Card_In_CardIssuer;
- if (IsContactlessCardSessionOK())
- (*m_pContactless)(EntityResource::getLink().upgradeLink())->CancelInsert();
- }
- else if (qciAns.position == 1) //GetDevStatus 调用异常
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("CardIssuerStand GetDevStatus failed");
- return 1;
- }
- else
- {
- if (m_bCancelAccept)
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("before call CardIssuerStand->Insert, have received cancel event");
- return 3;
- }
- CardIssuerStandService_Insert_Req req;
- CardIssuerStandService_Insert_Ans ans;
- req.aid = ctx->Req.aid;
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("to call cardissuerStand insert..");
- m_busCtx.eCardProcStage = Card_ProcStage_WaitForCard;
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->Insert(req, ans, 59000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Card insert into CardIssuerStand, cancel ContactlessCard.");
- bHasCard = true;
- m_busCtx.eCardFromWhich = Card_In_CardIssuer;
- m_busCtx.eCardProcStage = Card_ProcStage_Read;
- if (IsContactlessCardSessionOK())
- (*m_pContactless)(EntityResource::getLink().upgradeLink())->CancelInsert();
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("CardIssuerStand Insert return:%d", eErr);
- //oilyang@20200827 if time out, we must told front caller
- //AND set returned value of 0 to change FSM state
- if (eErr == Error_TimeOut)
- {
- return 7;
- }
- else
- return 1;//oilyang@20190709
- }
- }
- if (bHasCard)
- {
- CardIssuerStandService_Read_Req reqR;
- CardIssuerStandService_Read_Ans ansR;
- reqR.aid = ctx->Req.aid;
- reqR.reserved1 = ctx->Req.lightPos;
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("to read ctx->Req.lightPos:%d", ctx->Req.lightPos);
- Sleep(100);//zjw@20190725 以防卡机状态还未跳转,这里就已经触发了Read操作
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->Read(reqR, ansR, 50000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.track1 = ansR.track1;
- ctx->Ans.track2 = ansR.track2;
- ctx->Ans.track3 = ansR.track3;
- ctx->Ans.ICType = ansR.ICType;
- ctx->Ans.ICCardNo = ansR.ICData;
- ctx->Ans.status = ansR.status;
- ///**TODO(Gifur@8/22/2023): 增加单屏机型判断,需要诗友确认*/
- if (m_eMachineType == RVC_Stand2S || m_eMachineType == RVC_Stand1SPlus)
- ctx->Ans.cardPos = CardPos_CardIssuer_Stand2S;
- else
- ctx->Ans.cardPos = CardPos_CardIssuer_Split;
- ctx->Ans.t2Account = ansR.t2Account;
- ctx->Ans.t2Region = ansR.t2Region;
- ctx->Ans.t2CardSerial = ansR.t2CardSerial;
- ctx->Ans.t2CVC = ansR.t2CVC;
- ctx->Ans.t2ExpireDate = ansR.t2ExpireDate;
- if (ansR.ICType == 1 || ansR.ICType == 3)
- bNeedPreOnline = true;
- else
- bNeedPreOnline = false;
- }
- else
- {
- bNeedPreOnline = false;
- if (eErr == Error_DevMedia)
- bCardMismatch = true;
- }
- }
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("CardIssuerStand QueryCardInfo failed return:%d", eErr);
- return 1;//oilyang@20190709
- }
- if (bHasCard && bNeedPreOnline)
- {
- CardIssuerStandService_PreOnline_Req req;
- CardIssuerStandService_PreOnline_Ans ans;
- req.businessData = ctx->Req.businessData;
- BroadcastReadICing(0);
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("to preonline");
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->PreOnline(req, ans, 50000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.result = ans.result;
- ctx->Ans.status = 0;
- //oilyang@20220613 既然前面bNeedPreOnline给默认值,这里的判断也就失去了意义
- //if (ctx->Ans.ICType == 1 || ctx->Ans.ICType == 3)
- {
- CardIssuerStandService_SetSomeFlag_Req ssfReq;
- CardIssuerStandService_SetSomeFlag_Ans ssfAns;
- ssfReq.IssueBusiness = 4;
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->SetSomeFlag(ssfReq, ssfAns, 5000, dwUsrErrCode);
- if (eErr == Error_Succeed)
- ctx->Ans.ICCardNo = ssfAns.reserved2[0];
- else
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("CardIssuerStand SetSomeFlag failed return:%d", eErr);
- }
- }
- else
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("CardIssuerStand PreOnline failed return:%d", eErr);
- ctx->Ans.result = "";
- ctx->Ans.status = -1;
- }
- }
- if (bHasCard)
- {
- if (bCardMismatch)
- {
- //oiltmp@20221202 todo Error_DevNotAvailable should be changed if we have negotiated with hangzhou vtm developer
- ctx->Answer(Error_DevNotAvailable, CardIssuer_UserErrorCode_Account_EAC_Mismatch, csRetStr);
- }
- else
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ReadCard, the final errCode:%d,status:%d,dwUsrErrCode:%d", eErr, ctx->Ans.status, dwUsrErrCode);
- Sleep(300);//oilyang@20230202 for hardware entity to trans FSM state
- ctx->Answer(eErr, dwUsrErrCode, csRetStr);
- }
- }
- return 0;
- }
- else {
- CardIssuerStoreService_QueryCardInfo_Req qciReq;
- CardIssuerStoreService_QueryCardInfo_Ans qciAns;
- bool bHasCard = false, bNeedPreOnline = false, bCardMismatch = false;
- DWORD dwUsrErrCode = 0;
- CSimpleStringA csRetStr(true);
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->QueryCardInfo(qciReq, qciAns, 12000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- if (qciAns.position == 2)//有卡
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("CardIssuerStore has card, cancel ContactlessCard.");
- bHasCard = true;
- //oilyang@20220817 为什么要给默认值?Read失败,没有必要PreOnline
- //bNeedPreOnline = true;//不知道卡片类型,默认
- m_busCtx.eCardFromWhich = Card_In_CardIssuer;
- if (IsContactlessCardSessionOK())
- (*m_pContactless)(EntityResource::getLink().upgradeLink())->CancelInsert();
- }
- else if (qciAns.position == 1) //GetDevStatus 调用异常
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("CardIssuerStore GetDevStatus failed");
- return 1;
- }
- else
- {
- if (m_bCancelAccept)
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("before call CardIssuerStore->Insert, have received cancel event");
- return 3;
- }
- CardIssuerStoreService_Insert_Req req;
- CardIssuerStoreService_Insert_Ans ans;
- req.aid = ctx->Req.aid;
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("to call cardissuerStore insert..");
- m_busCtx.eCardProcStage = Card_ProcStage_WaitForCard;
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->Insert(req, ans, 59000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Card insert into CardIssuerStore, cancel ContactlessCard.");
- bHasCard = true;
- m_busCtx.eCardFromWhich = Card_In_CardIssuer;
- m_busCtx.eCardProcStage = Card_ProcStage_Read;
- if (IsContactlessCardSessionOK())
- (*m_pContactless)(EntityResource::getLink().upgradeLink())->CancelInsert();
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("CardIssuerStore Insert return:%d", eErr);
- //oilyang@20200827 if time out, we must told front caller
- //AND set returned value of 0 to change FSM state
- if (eErr == Error_TimeOut)
- {
- return 7;
- }
- else
- return 1;//oilyang@20190709
- }
- }
- if (bHasCard)
- {
- CardIssuerStoreService_Read_Req reqR;
- CardIssuerStoreService_Read_Ans ansR;
- reqR.aid = ctx->Req.aid;
- reqR.reserved1 = ctx->Req.lightPos;
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("to read ctx->Req.lightPos:%d", ctx->Req.lightPos);
- Sleep(100);//zjw@20190725 以防卡机状态还未跳转,这里就已经触发了Read操作
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->Read(reqR, ansR, 50000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.track1 = ansR.track1;
- ctx->Ans.track2 = ansR.track2;
- ctx->Ans.track3 = ansR.track3;
- ctx->Ans.ICType = ansR.ICType;
- ctx->Ans.ICCardNo = ansR.ICData;
- ctx->Ans.status = ansR.status;
- ///**TODO(Gifur@8/22/2023): 增加单屏机型判断,需要诗友确认*/
- if (m_eMachineType == RVC_Stand2S || m_eMachineType == RVC_Stand1SPlus)
- ctx->Ans.cardPos = CardPos_CardIssuer_Stand2S;
- else
- ctx->Ans.cardPos = CardPos_CardIssuer_Split;
- ctx->Ans.t2Account = ansR.t2Account;
- ctx->Ans.t2Region = ansR.t2Region;
- ctx->Ans.t2CardSerial = ansR.t2CardSerial;
- ctx->Ans.t2CVC = ansR.t2CVC;
- ctx->Ans.t2ExpireDate = ansR.t2ExpireDate;
- if (ansR.ICType == 1 || ansR.ICType == 3)
- bNeedPreOnline = true;
- else
- bNeedPreOnline = false;
- }
- else
- {
- bNeedPreOnline = false;
- if (eErr == Error_DevMedia)
- bCardMismatch = true;
- }
- }
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("CardIssuerStore QueryCardInfo failed return:%d", eErr);
- return 1;//oilyang@20190709
- }
- if (bHasCard && bNeedPreOnline)
- {
- CardIssuerStoreService_PreOnline_Req req;
- CardIssuerStoreService_PreOnline_Ans ans;
- req.businessData = ctx->Req.businessData;
- BroadcastReadICing(0);
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("to preonline");
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->PreOnline(req, ans, 50000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.result = ans.result;
- ctx->Ans.status = 0;
- //oilyang@20220613 既然前面bNeedPreOnline给默认值,这里的判断也就失去了意义
- //if (ctx->Ans.ICType == 1 || ctx->Ans.ICType == 3)
- {
- CardIssuerStoreService_SetSomeFlag_Req ssfReq;
- CardIssuerStoreService_SetSomeFlag_Ans ssfAns;
- ssfReq.IssueBusiness = 4;
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->SetSomeFlag(ssfReq, ssfAns, 5000, dwUsrErrCode);
- if (eErr == Error_Succeed)
- ctx->Ans.ICCardNo = ssfAns.reserved2[0];
- else
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("CardIssuerStore SetSomeFlag failed return:%d", eErr);
- }
- }
- else
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("CardIssuerStore PreOnline failed return:%d", eErr);
- ctx->Ans.result = "";
- ctx->Ans.status = -1;
- }
- }
- if (bHasCard)
- {
- if (bCardMismatch)
- {
- //oiltmp@20221202 todo Error_DevNotAvailable should be changed if we have negotiated with hangzhou vtm developer
- ctx->Answer(Error_DevNotAvailable, CardIssuer_UserErrorCode_Account_EAC_Mismatch, csRetStr);
- }
- else
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ReadCard, the final errCode:%d,status:%d,dwUsrErrCode:%d", eErr, ctx->Ans.status, dwUsrErrCode);
- Sleep(300);//oilyang@20230202 for hardware entity to trans FSM state
- ctx->Answer(eErr, dwUsrErrCode, csRetStr);
- }
- }
- return 0;
- }
- }
- return 1;
- }
- int CCardReadAdapterFSM::ContactlessCardRead(SpReqAnsContext<CardReadAdapterService_Read_Req, CardReadAdapterService_Read_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- if (m_bCancelAccept || (m_busCtx.eCardFromWhich == Card_In_CardIssuer))
- {
- char msg[128];
- memset(msg, 0, 128);
- sprintf(msg, "Maybe the thread pool is wrong.ContactlessCardRead,bCancel:%d,cardpos:%d", m_bCancelAccept, m_busCtx.eCardFromWhich);
- //oilyang@20220917 发卡时,处于持卡状态,属于误判,然而精准的区分也不容易,暂时这么处理
- //LogWarn(Severity_Middle, Error_NotInit, CardReadAdapter_UserErrorCode_MayBe_ThreadPool_Wrong, msg);
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)(msg);
- return 3;
- }
- ErrorCodeEnum eErr = Error_Unexpect;
- DWORD elapsed = 0;
- DWORD dwStart = GetTickCountRVC();
- DWORD dwEnd = GetTickCountRVC();
- int insertloopNum = 0;
- int preloopNum = 0;
- while(elapsed + ReadCard_Min_Time < ReadCard_TIMEOUT)
- {
- if (IsTheEntity(ctx->Req.module, Module_ContactlessCard) && IsContactlessCardSessionOK())
- {
- bool bFindCard = false;
- ContactlessCardService_Insert_Req req;
- ContactlessCardService_Insert_Ans ans;
- DWORD dwUserCode = 0;
- req.aid = ctx->Req.aid;
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("to call contactless insert...");
- dwEnd = GetTickCountRVC();
- DWORD dwTimeout = ReadCard_TIMEOUT - (dwEnd-dwStart);
- m_busCtx.eCardFromWhich = Card_In_No_Where;
- m_busCtx.eCardProcStage = Card_ProcStage_WaitForCard;
- if (insertloopNum % 10 == 0) {
- req.reserved1 = "P";
- }
- eErr = (*m_pContactless)(EntityResource::getLink().upgradeLink())->Insert(req, ans, dwTimeout, dwUserCode);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.track1 = ans.track1;
- ctx->Ans.track2 = ans.track2;
- ctx->Ans.track3 = ans.track3;
- ctx->Ans.ICType = ans.ICType;
- ctx->Ans.ICCardNo = ans.ICData;
- ctx->Ans.status = ans.status;
- ctx->Ans.cardPos = CardPos_ContactlessCard;
- ctx->Ans.t2Account = ans.t2Account;
- ctx->Ans.t2Region = ans.t2Region;
- ctx->Ans.t2CardSerial = ans.t2CardSerial;
- ctx->Ans.t2CVC = ans.t2CVC;
- ctx->Ans.t2ExpireDate = ans.t2ExpireDate;
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Card in ContactlessCard.");
- m_busCtx.eCardFromWhich = Card_In_ContactlessCard;
- m_busCtx.eCardProcStage = Card_ProcStage_Read;
- //if (IsCardIssuerSessionOK()){
- // (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->CancelInsert();
- //}
- if (ans.ICType == 4)
- {
- bFindCard = true;
- }else{
- return 0;
- }
- }
- else if (eErr == Error_TimeOut)
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("ContactlessCard timeout.");
- return 8;
- }else if(eErr == Error_Cancel){
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("ContactlessCard canceled or be canceled.");
- return 1;
- }
- else if(eErr == Error_Interact){
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("maybe ICCommand error, need loop!!!");
- dwEnd = GetTickCountRVC();
- elapsed = dwEnd - dwStart;
- Sleep(400);
- insertloopNum++;
- continue;
- }
- else if(eErr == Error_DevNotAvailable || eErr == Error_InvalidState)//设备不可用或实体异常
- {
- //ctx->Answer(eErr, dwUserCode);
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)(CSimpleStringA::Format("ContactlessCard read failed(%d)(%d)", eErr, dwUserCode));
- return 1;
- }else if(eErr == Error_Unexpect){
- ctx->Answer(eErr, dwUserCode);
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)(CSimpleStringA::Format("ContactlessCard read failed(%d)(%d)", eErr, dwUserCode));
- return 2;
- }
- if (bFindCard)
- {
- //oilyang@20210223 add,The Entity FSM is too late to change state ,as the call coming so fast
- Sleep(200);
- dwEnd = GetTickCountRVC();
- DWORD elapsed1 = ReadCard_TIMEOUT - (dwEnd-dwStart);
- if(elapsed1 < 5000)//PreOnline较慢,预留一定时间
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("There is no more time to invoke PreOnline");
- ctx->Ans.result = "";
- return 8;
- }
- ContactlessCardService_PreOnline_Req req;
- ContactlessCardService_PreOnline_Ans ans;
- req.businessData = ctx->Req.businessData;
- BroadcastReadICing(0);
- if (preloopNum % 10 == 0) {
- req.reserved1 = "P";
- }
- eErr = (*m_pContactless)(EntityResource::getLink().upgradeLink())->PreOnline(req, ans, 50000);
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)(CSimpleStringA::Format("ContacelssCard PreOnline result:%d", eErr));
- if (eErr == Error_Succeed)
- {
- ctx->Ans.result = ans.result;
- ctx->Ans.status = 0;
- }else if(eErr == Error_Interact){
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("ContacelssCard return Error_Interact, need loop.");
- dwEnd = GetTickCountRVC();
- elapsed = dwEnd - dwStart;
- preloopNum++;
- Sleep(400);
- continue;
- }
- else
- {
- ctx->Ans.result = "";
- ctx->Ans.status = -1;
- }
- ctx->Answer(eErr);
- return 0;
- }
- //ctx->Answer(eErr);
- }else{
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)(CSimpleStringA::Format("can't find the corresponding Entity.req.Module:%d", ctx->Req.module));
- return 0;
- }
- }
- return 8;
- }
- int CCardReadAdapterFSM::IssueCard(SpReqAnsContext<CardReadAdapterService_Issue_Req, CardReadAdapterService_Issue_Ans>::Pointer ctx)
- {
- if (IsTheEntity(ctx->Req.module, Module_CardIssuer) && IsCardIssuerSessionOK())
- {
- if (!IsCardIssuerStore()) {
- ErrorCodeEnum eErr = Error_Unexpect;
- CardIssuerStandService_IssueEx_Req req;
- CardIssuerStandService_IssueEx_Ans ans;
- req.hopper = ctx->Req.hopper;
- req.reserved1.Copy(ctx->Req.reserved1);
- req.reserved2.Copy(ctx->Req.reserved2);
- DWORD dwUsrErrCode = 0;
- CSimpleStringA csRetStr(true);
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->IssueEx(req, ans, 60000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- if (ans.reserved1.GetCount() > 0)
- ctx->Ans.reserved1.Copy(ans.reserved1);
- if (ans.reserved2.GetCount() > 0)
- ctx->Ans.reserved2.Copy(ans.reserved2);
- // --Josephus at 11:09:47 201747
- //oilyang@20180315 kaku
- //if(m_busCtx.eCardFromWhich == Card_In_No_Where)
- if (req.hopper == 99 || req.hopper == 98 || req.hopper == 89)
- {
- if (ans.reserved1[0] == 0 && ans.reserved1[1] == 0)
- m_busCtx.eCardFromWhich = Card_In_CardIssuer;
- }
- else if (req.hopper == 88 || req.hopper == 87)
- {
- m_busCtx.eCardFromWhich = Card_In_No_Where;
- }
- else
- m_busCtx.eCardFromWhich = Card_In_CardIssuer;
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("req.hopper:%d Deem that CardIssuerStand has card after issuing succ. Set busCtx:findCard:%d,cardPos:%d"
- , req.hopper, ans.reserved1[0], ans.reserved1[1]);
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("CardIssuerStand IssueCard failed return:%d", eErr);
- }
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("oiltest IssueEx retStr:%s", csRetStr.GetData());
- ctx->Answer(eErr, dwUsrErrCode, csRetStr);
- return 0;
- }
- else {
- ErrorCodeEnum eErr = Error_Unexpect;
- CardIssuerStoreService_IssueEx_Req req;
- CardIssuerStoreService_IssueEx_Ans ans;
- req.hopper = ctx->Req.hopper;
- req.reserved1.Copy(ctx->Req.reserved1);
- req.reserved2.Copy(ctx->Req.reserved2);
- DWORD dwUsrErrCode = 0;
- CSimpleStringA csRetStr(true);
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->IssueEx(req, ans, 60000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- if (ans.reserved1.GetCount() > 0)
- ctx->Ans.reserved1.Copy(ans.reserved1);
- if (ans.reserved2.GetCount() > 0)
- ctx->Ans.reserved2.Copy(ans.reserved2);
- // --Josephus at 11:09:47 201747
- //oilyang@20180315 kaku
- //if(m_busCtx.eCardFromWhich == Card_In_No_Where)
- if (req.hopper == 99 || req.hopper == 98 || req.hopper == 89)
- {
- if (ans.reserved1[0] == 0 && ans.reserved1[1] == 0)
- m_busCtx.eCardFromWhich = Card_In_CardIssuer;
- }
- else if (req.hopper == 88 || req.hopper == 87)
- {
- m_busCtx.eCardFromWhich = Card_In_No_Where;
- }
- else
- m_busCtx.eCardFromWhich = Card_In_CardIssuer;
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("req.hopper:%d Deem that CardIssuerStore has card after issuing succ. Set busCtx:findCard:%d,cardPos:%d"
- , req.hopper, ans.reserved1[0], ans.reserved1[1]);
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("CardIssuerStore IssueCard failed return:%d", eErr);
- }
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("oiltest IssueEx retStr:%s", csRetStr.GetData());
- ctx->Answer(eErr, dwUsrErrCode, csRetStr);
- return 0;
- }
-
- }
- else
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("issue card param error or connection is failed:(module)%d",ctx->Req.module);
- ctx->Answer(Error_Param);
- return 1;
- }
- }
- void CCardReadAdapterFSM::CancelRead()
- {
- ErrorCodeEnum eErr = Error_Unexpect;
- if (IsCardIssuerSessionOK())
- {
- if (!IsCardIssuerStore()) {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("CardIssuerStand read canceled by front user.");
- (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->CancelInsert();
- }
- else {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("CardIssuerStore read canceled by front user.");
- (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->CancelInsert();
- }
- }
- if (IsContactlessCardSessionOK())
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("ContactlessCard read canceled by front user.");
- (*m_pContactless)(EntityResource::getLink().upgradeLink())->CancelInsert();
- }
- }
- void CCardReadAdapterFSM::ReadWaitMore()
- {
- ErrorCodeEnum eErr = Error_Unexpect;
- if (IsCardIssuerSessionOK())
- {
- if (!IsCardIssuerStore()) {
- (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->InsertWaitMore();
- }
- else {
- (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->InsertWaitMore();
- }
-
- }
- if (IsContactlessCardSessionOK())
- {
- (*m_pContactless)(EntityResource::getLink().upgradeLink())->InsertWaitMore();
- }
- }
- int CCardReadAdapterFSM::WriteTrack(SpReqAnsContext<CardReadAdapterService_WriteTrack_Req, CardReadAdapterService_WriteTrack_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- if (IsCardIssuerSessionOK())
- {
- if (!IsCardIssuerStore()) {
- CardIssuerStandService_WriteTrack_Req req;
- CardIssuerStandService_WriteTrack_Ans ans;
- req.co = ctx->Req.co;
- req.mode = ctx->Req.mode;
- req.track1 = ctx->Req.track1;
- req.track2 = ctx->Req.track2;
- req.track3 = ctx->Req.track3;
- req.reserved = ctx->Req.reserved;
- ErrorCodeEnum eErr = Error_Unexpect;
- DWORD dwUsrErrCode = 0;
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->WriteTrack(req, ans, 20000, dwUsrErrCode);
- if (eErr != Error_Succeed)
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("WriteTrack failed.%d", eErr);
- ctx->Answer(eErr, dwUsrErrCode);
- }
- else
- {
- ctx->Ans.result = ans.result;
- ctx->Ans.reserved1 = ans.reserved1;
- ctx->Ans.reserved2 = ans.reserved2;
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("Write tracks ok.");
- ctx->Answer(Error_Succeed);
- }
- }
- else {
- CardIssuerStoreService_WriteTrack_Req req;
- CardIssuerStoreService_WriteTrack_Ans ans;
- req.co = ctx->Req.co;
- req.mode = ctx->Req.mode;
- req.track1 = ctx->Req.track1;
- req.track2 = ctx->Req.track2;
- req.track3 = ctx->Req.track3;
- req.reserved = ctx->Req.reserved;
- ErrorCodeEnum eErr = Error_Unexpect;
- DWORD dwUsrErrCode = 0;
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->WriteTrack(req, ans, 20000, dwUsrErrCode);
- if (eErr != Error_Succeed)
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("WriteTrack failed.%d", eErr);
- ctx->Answer(eErr, dwUsrErrCode);
- }
- else
- {
- ctx->Ans.result = ans.result;
- ctx->Ans.reserved1 = ans.reserved1;
- ctx->Ans.reserved2 = ans.reserved2;
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("Write tracks ok.");
- ctx->Answer(Error_Succeed);
- }
- }
- }
- return 0;
- }
- int CCardReadAdapterFSM::PreOnline(SpReqAnsContext<CardReadAdapterService_PreOnline_Req, CardReadAdapterService_PreOnline_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- ErrorCodeEnum eErr = Error_Unexpect;
- DWORD dwUsrErrCode = 0;
- CSimpleStringA csRetStr(true);
- if (IsTheEntity(ctx->Req.module, Module_CardIssuer) && IsCardIssuerSessionOK())
- {
- if (!IsCardIssuerStore()) {
- CardIssuerStandService_PreOnline_Req req;
- CardIssuerStandService_PreOnline_Ans ans;
- req.businessData = ctx->Req.businessData;
- if (!ctx->Req.reserved2[0].IsNullOrEmpty())
- req.reserved1 = ctx->Req.reserved2[0];
- else
- req.reserved1 = "";
- if (!ctx->Req.reserved2[1].IsNullOrEmpty())
- req.reserved2 = ctx->Req.reserved2[1];
- else
- req.reserved2 = "";
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->PreOnline(req, ans, 50000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.result = ans.result;
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("PreOnline, CardIssuerStand PreOnline failed return:%d", eErr);
- }
- ctx->Answer(eErr, dwUsrErrCode, csRetStr);
- }
- else {
- CardIssuerStoreService_PreOnline_Req req;
- CardIssuerStoreService_PreOnline_Ans ans;
- req.businessData = ctx->Req.businessData;
- if (!ctx->Req.reserved2[0].IsNullOrEmpty())
- req.reserved1 = ctx->Req.reserved2[0];
- else
- req.reserved1 = "";
- if (!ctx->Req.reserved2[1].IsNullOrEmpty())
- req.reserved2 = ctx->Req.reserved2[1];
- else
- req.reserved2 = "";
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->PreOnline(req, ans, 50000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.result = ans.result;
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("PreOnline, CardIssuerStore PreOnline failed return:%d", eErr);
- }
- ctx->Answer(eErr, dwUsrErrCode, csRetStr);
- }
- }
- else if (IsTheEntity(ctx->Req.module, Module_ContactlessCard) && IsContactlessCardSessionOK() && m_busCtx.eCardFromWhich == Card_In_ContactlessCard)
- {
- ContactlessCardService_PreOnline_Req req;
- ContactlessCardService_PreOnline_Ans ans;
- req.businessData = ctx->Req.businessData;
- //req.reserved1 = ctx->Req.reserved1;
- //req.reserved2 = ctx->Req.reserved2;
- eErr = (*m_pContactless)(EntityResource::getLink().upgradeLink())->PreOnline(req, ans, 50000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.result = ans.result;
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)(CSimpleStringA::Format("PreOnline, ContactlessCard PreOnline failed return:%d", eErr));
- }
- ctx->Answer(eErr, dwUsrErrCode, csRetStr);
- }
- return 0;
- }
- int CCardReadAdapterFSM::PostOnline(SpReqAnsContext<CardReadAdapterService_PostOnline_Req, CardReadAdapterService_PostOnline_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("<PostOnline>, ctx->Req.module:%d,cardIn(Iss 1,RF 2):%d", ctx->Req.module, m_busCtx.eCardFromWhich);
- ErrorCodeEnum eErr = Error_Unexpect;
- DWORD dwUsrErrCode = 0;
- CSimpleStringA csRetStr(true);
- if (IsTheEntity(ctx->Req.module, Module_CardIssuer) && IsCardIssuerSessionOK() && m_busCtx.eCardFromWhich == Card_In_CardIssuer)
- {
- if (!IsCardIssuerStore()) {
- CardIssuerStandService_PostOnline_Req req;
- CardIssuerStandService_PostOnline_Ans ans;
- req.data = ctx->Req.data;
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->PostOnline(req, ans, 50000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.result = ans.result;
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("PostOnline, CardIssuerStand PostOnline failed return:%d", eErr);
- }
- ctx->Answer(eErr, dwUsrErrCode, csRetStr);
- }
- else {
- CardIssuerStoreService_PostOnline_Req req;
- CardIssuerStoreService_PostOnline_Ans ans;
- req.data = ctx->Req.data;
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->PostOnline(req, ans, 50000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.result = ans.result;
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("PostOnline, CardIssuerStore PostOnline failed return:%d", eErr);
- }
- ctx->Answer(eErr, dwUsrErrCode, csRetStr);
- }
- }
- else if (IsTheEntity(ctx->Req.module, Module_ContactlessCard) && IsContactlessCardSessionOK() && m_busCtx.eCardFromWhich == Card_In_ContactlessCard)
- {
- ContactlessCardService_PostOnline_Req req;
- ContactlessCardService_PostOnline_Ans ans;
- req.data = ctx->Req.data;
- eErr = (*m_pContactless)(EntityResource::getLink().upgradeLink())->PostOnline(req, ans, 50000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.result = ans.result;
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("PostOnline, ContactlessCard PostOnline failed return:%d", eErr);
- }
- ctx->Answer(eErr, dwUsrErrCode, csRetStr);
- }
- return 0;
- }
- int CCardReadAdapterFSM::EjectCard(SpReqAnsContext<CardReadAdapterService_Eject_Req, CardReadAdapterService_Eject_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- Sleep(100);//oilyang@20230202 for hardware entity to trans FSM state
- ErrorCodeEnum eErr = Error_Unexpect;
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("before eject card,req.module %d,card in %d", ctx->Req.module,m_busCtx.eCardFromWhich);
- DWORD dwUsrErrCode = 0;
- CSimpleStringA csRetStr(true);
- if (IsTheEntity(ctx->Req.module, Module_CardIssuer) && IsCardIssuerSessionOK() && m_busCtx.eCardFromWhich == Card_In_CardIssuer)
- {
- if (!IsCardIssuerStore()) {
- CardIssuerStandService_Eject_Req req;
- CardIssuerStandService_Eject_Ans ans;
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->Eject(req, ans, 50000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- m_busCtx.eCardFromWhich = Card_In_No_Where;
- m_busCtx.eCardProcStage = Card_ProcStage_Eject;
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("CardIssuerStand EjectCard suc.");
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("EjectCard, CardIssuerStand EjectCard failed return:%d", eErr);
- }
- ctx->Answer(eErr, dwUsrErrCode, csRetStr);
- }
- else {
- CardIssuerStoreService_Eject_Req req;
- CardIssuerStoreService_Eject_Ans ans;
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->Eject(req, ans, 50000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- m_busCtx.eCardFromWhich = Card_In_No_Where;
- m_busCtx.eCardProcStage = Card_ProcStage_Eject;
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("CardIssuerStore EjectCard suc.");
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("EjectCard, CardIssuerStore EjectCard failed return:%d", eErr);
- }
- ctx->Answer(eErr, dwUsrErrCode, csRetStr);
- }
- }
- else if (IsTheEntity(ctx->Req.module, Module_ContactlessCard) && IsContactlessCardSessionOK() && m_busCtx.eCardFromWhich == Card_In_ContactlessCard)
- {
- ContactlessCardService_Eject_Req req;
- ContactlessCardService_Eject_Ans ans;
- eErr = (*m_pContactless)(EntityResource::getLink().upgradeLink())->Eject(req, ans, 50000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- m_busCtx.eCardFromWhich = Card_In_No_Where;
- m_busCtx.eCardProcStage = Card_ProcStage_Eject;
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ContactlessCard EjectCard suc.");
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("EjectCard, ContactlessCard EjectCard failed return:%d", eErr);
- }
- ctx->Answer(eErr, dwUsrErrCode, csRetStr);
- }
- else
- {
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("EjectCard, nothing to do.");
- ctx->Answer(Error_NotExist);
- }
- return 0;
- }
- int CCardReadAdapterFSM::CaptureCard(SpReqAnsContext<CardReadAdapterService_Capture_Req, CardReadAdapterService_Capture_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- Sleep(100);//oilyang@20230202 for hardware entity to trans FSM state
- ErrorCodeEnum eErr = Error_Unexpect;
- DWORD dwUsrErrCode = 0;
- CSimpleStringA csRetStr(true);
- if (IsTheEntity(ctx->Req.module, Module_CardIssuer) && IsCardIssuerSessionOK() && m_busCtx.eCardFromWhich == Card_In_CardIssuer)
- {
- if (!IsCardIssuerStore()) {
- CardIssuerStandService_Capture_Req req;
- CardIssuerStandService_Capture_Ans ans;
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->Capture(req, ans, 15000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("CardIssuerStand Capture card suc.");
- m_busCtx.eCardFromWhich = Card_In_No_Where;
- m_busCtx.eCardProcStage = Card_ProcStage_Capture;
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("CaptureCard, CardIssuerStand Capture failed return:%d", eErr);
- }
- ctx->Answer(eErr, dwUsrErrCode, csRetStr);
- }
- else {
- CardIssuerStoreService_Capture_Req req;
- CardIssuerStoreService_Capture_Ans ans;
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->Capture(req, ans, 15000, dwUsrErrCode, csRetStr);
- if (eErr == Error_Succeed)
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("CardIssuerStore Capture card suc.");
- m_busCtx.eCardFromWhich = Card_In_No_Where;
- m_busCtx.eCardProcStage = Card_ProcStage_Capture;
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("CaptureCard, CardIssuerStore Capture failed return:%d", eErr);
- }
- ctx->Answer(eErr, dwUsrErrCode, csRetStr);
- }
- }
- else
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("CaptureCard, Something wrong.the module(%d),cardinwhere(%d)", ctx->Req.module, m_busCtx.eCardFromWhich);
- ctx->Answer(eErr);
- }
- return 0;
- }
- int CCardReadAdapterFSM::QueryCardInfo(SpReqAnsContext<CardReadAdapterService_QueryCardInfo_Req, CardReadAdapterService_QueryCardInfo_Ans>::Pointer ctx)
- {
- ErrorCodeEnum eErr = Error_Unexpect;
- DWORD dwUsrErrCode = 0;
- ctx->Ans.CardIssuerPos = ctx->Ans.ContactlessCardPos = ctx->Ans.CardSwiperPos = 0;
- if (IsTheEntity(ctx->Req.module, Module_CardIssuer) && IsCardIssuerSessionOK() && m_busCtx.eCardFromWhich == Card_In_CardIssuer)
- {
- if (!IsCardIssuerStore()) {
- CardIssuerStandService_QueryCardInfo_Req req;
- CardIssuerStandService_QueryCardInfo_Ans ans;
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->QueryCardInfo(req, ans, 10000, dwUsrErrCode);
- if (eErr == Error_Succeed)
- {
- switch (ans.position)
- {
- case 1:
- ctx->Ans.CardIssuerPos = -1;
- break;
- case 2:
- ctx->Ans.CardIssuerPos = 1;
- break;
- default:
- break;
- }
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("QueryCardInfo, CardIssuerStand QueryCardInfo failed return:%d", eErr);
- }
- }
- else {
- CardIssuerStoreService_QueryCardInfo_Req req;
- CardIssuerStoreService_QueryCardInfo_Ans ans;
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->QueryCardInfo(req, ans, 10000, dwUsrErrCode);
- if (eErr == Error_Succeed)
- {
- switch (ans.position)
- {
- case 1:
- ctx->Ans.CardIssuerPos = -1;
- break;
- case 2:
- ctx->Ans.CardIssuerPos = 1;
- break;
- default:
- break;
- }
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("QueryCardInfo, CardIssuerStore QueryCardInfo failed return:%d", eErr);
- }
- }
- }
- if (IsTheEntity(ctx->Req.module, Module_ContactlessCard) && IsContactlessCardSessionOK() && m_busCtx.eCardFromWhich == Card_In_ContactlessCard)
- {
- ContactlessCardService_QueryCardInfo_Req req;
- ContactlessCardService_QueryCardInfo_Ans ans;
- eErr = (*m_pContactless)(EntityResource::getLink().upgradeLink())->QueryCardInfo(req, ans, 10000, dwUsrErrCode);
- if (eErr == Error_Succeed)
- {
- switch (ans.position)//oiltmp to add
- {
- case 2:
- break;
- case 3:
- break;
- case 4:
- ctx->Ans.ContactlessCardPos = 1;
- break;
- default:
- break;
- }
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("QueryCardInfo, ContactlessCard QueryCardInfo failed return:%d", eErr);
- ctx->Ans.ContactlessCardPos = -1;
- }
- }
- ctx->Answer(Error_Succeed);
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("<QueryCardInfo>, CardFromWhich:%d, position(CI,CC,CS) %d,%d,%d",
- m_busCtx.eCardFromWhich, ctx->Ans.CardIssuerPos, ctx->Ans.ContactlessCardPos, ctx->Ans.CardSwiperPos);
- return 0;
- }
- void CCardReadAdapterFSM::CheckAndReconnectSession()
- {
- ErrorCodeEnum eErr = Error_Unexpect;
- int cardIssuerCount = 0, contactlessCardCount = 0;
- while (1)
- {
- //the first time to connect or need to reconnect
- //分为卡机和卡库
- if (!IsCardIssuerStore()) {
- if ((m_pCardIssuer == NULL || (m_pCardIssuer != NULL && m_pCardIssuer->QuerySessionClosed())))
- {
- if (m_pCardIssuer != NULL)
- {
- m_pCardIssuer->GetFunction()->CloseSession();
- m_pCardIssuer = NULL;
- }
- m_pCardIssuer = new CardIssuerStandService_ClientBase(GetEntityBase());
- if (m_pCardIssuer != NULL)
- {
- eErr = m_pCardIssuer->Connect();
- if (eErr != Error_Succeed)
- {
- if (cardIssuerCount % 120 == 0)//about 10 minutes can't connect to entity
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("connect to entity CardIssuerStand failed.%d", eErr);
- cardIssuerCount++;
- m_pCardIssuer->SafeDelete();
- m_pCardIssuer = NULL;
- }
- else
- {
- cardIssuerCount = 0;
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Connect to entity CardIssuerStand suc.");
- }
- }
- }
- }
- else {
- //CardIssuerStore
- if ((m_pCardIssuerStore == NULL || (m_pCardIssuerStore != NULL && m_pCardIssuerStore->QuerySessionClosed())))
- {
- if (m_pCardIssuerStore != NULL)
- {
- m_pCardIssuerStore->GetFunction()->CloseSession();
- m_pCardIssuerStore = NULL;
- }
- m_pCardIssuerStore = new CardIssuerStoreService_ClientBase(GetEntityBase());
- if (m_pCardIssuerStore != NULL)
- {
- eErr = m_pCardIssuerStore->Connect();
- if (eErr != Error_Succeed)
- {
- if (cardIssuerCount % 120 == 0)//about 10 minutes can't connect to entity
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("connect to entity CardIssuerStore failed.%d", eErr);
- cardIssuerCount++;
- m_pCardIssuerStore->SafeDelete();
- m_pCardIssuerStore = NULL;
- }
- else
- {
- cardIssuerCount = 0;
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Connect to entity CardIssuerStore suc.");
- }
- }
- }
- }
- //ContactlessCard
- if ((m_eMachineType != RVC_CardStore && m_eMachineType != RVC_CardPrinter)
- && (m_pContactless == NULL || (m_pContactless != NULL && m_pContactless->QuerySessionClosed())))
- {
- if (m_pContactless != NULL)
- {
- m_pContactless->GetFunction()->CloseSession();
- m_pContactless = NULL;
- }
- m_pContactless = new ContactlessCardService_ClientBase(GetEntityBase());
- if (m_pContactless != NULL)
- {
- eErr = m_pContactless->Connect();
- if (eErr != Error_Succeed)
- {
- if (contactlessCardCount % 120 == 0)//about 10 minutes can't connect to entity
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("connect to entity ContactlessCard failed.%d", eErr);
- contactlessCardCount++;
- m_pContactless->SafeDelete();
- m_pContactless = NULL;
- }
- else
- {
- contactlessCardCount = 0;
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Connect to entity ContactlessCard suc.");
- }
- }
- }
- Sleep(5000);
- }
- }
- bool CCardReadAdapterFSM::IsCardIssuerSessionOK()
- {
- if (!IsCardIssuerStore()) {
- if (m_pCardIssuer != NULL && !m_pCardIssuer->QuerySessionClosed()) {
- return true;
- }
- }
- else {
- if (m_pCardIssuerStore != NULL && !m_pCardIssuerStore->QuerySessionClosed()) {
- return true;
- }
- }
- return false;
- }
- bool CCardReadAdapterFSM::IsContactlessCardSessionOK()
- {
- if (m_pContactless != NULL && !m_pContactless->QuerySessionClosed())
- return true;
- return false;
- }
- bool CCardReadAdapterFSM::IsTheEntity(int module,ModuleType eModule)
- {
- if (module == 0)
- return true;
- //oilyang@20180409 add req.module==99
- else if (module == 99)
- {
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("req.module is 99,machineType is:%s",m_csMachineType.GetData());
- //oilyang@20200730 according to meeting with Ratail/Test/Hangzhou
- //from guodan 20180905
- //99:进卡读卡,功能集向除蓝牙发卡机之外的读卡实体发出进卡读卡指令。
-
- if (eModule == Module_CardIssuer)
- {
- if (m_eMachineType == RVC_Stand2S
- || m_eMachineType == RVC_CardStore
- || m_eMachineType == RVC_CardPrinter
- || m_eMachineType == RVC_Stand1SPlus)
- return true;
- else
- return false;
- }
- else
- return true;
- }
- else if ((module&eModule) == eModule)
- return true;
- else
- return false;
- }
- int CCardReadAdapterFSM::SetSomeFlag(SpReqAnsContext<CardReadAdapterService_SetSomeFlag_Req, CardReadAdapterService_SetSomeFlag_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- if (IsCardIssuerSessionOK())
- {
- if (!IsCardIssuerStore()) {
- CardIssuerStandService_SetSomeFlag_Req req;
- CardIssuerStandService_SetSomeFlag_Ans ans;
- req.IssueBusiness = ctx->Req.IssueBusiness;
- req.reserved1.Init(ctx->Req.reserved1.GetCount());
- for (int i = 0; i < ctx->Req.reserved1.GetCount(); ++i)
- {
- req.reserved1[i] = ctx->Req.reserved1[i];
- }
- ErrorCodeEnum eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->SetSomeFlag(req, ans, 10000);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.reserved1.Copy(ans.reserved1);
- ctx->Ans.reserved2.Copy(ans.reserved2);
- ctx->Answer(Error_Succeed);
- }
- else {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("CardIssuerStand SetSomeFlag failed return:%d", eErr);
- ctx->Answer(Error_Unexpect);
- }
- }
- else {
- CardIssuerStoreService_SetSomeFlag_Req req;
- CardIssuerStoreService_SetSomeFlag_Ans ans;
- req.IssueBusiness = ctx->Req.IssueBusiness;
- req.reserved1.Init(ctx->Req.reserved1.GetCount());
- for (int i = 0; i < ctx->Req.reserved1.GetCount(); ++i)
- {
- req.reserved1[i] = ctx->Req.reserved1[i];
- }
- ErrorCodeEnum eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->SetSomeFlag(req, ans, 10000);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.reserved1.Copy(ans.reserved1);
- ctx->Ans.reserved2.Copy(ans.reserved2);
- ctx->Answer(Error_Succeed);
- }
- else {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("CardIssuerStore SetSomeFlag failed return:%d", eErr);
- ctx->Answer(Error_Unexpect);
- }
- }
- }
- else
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("SetSomeFlag is err, session is not ok");
- ctx->Answer(Error_Unexpect);
- }
- return 0;
- }
- int CCardReadAdapterFSM::GetDevInfo(SpReqAnsContext<CardReadAdapterService_GetDevInfo_Req, CardReadAdapterService_GetDevInfo_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- CSimpleStringA csCIType(""), csCIModel(""), csCIVersion(""), csCCType(""), csCCModel(""), csCCVersion(""), csCSType(""), csCSModel(""), csCSVersion("");
- int ciState, ccState, csState;
- bool bCI(false), bCC(false), bCS(false);
- ErrorCodeEnum eErr = Error_Unexpect;
- int count = 0;
- if (IsTheEntity(ctx->Req.module, Module_CardIssuer) && IsCardIssuerSessionOK())
- {
- if (!IsCardIssuerStore()) {
- CardIssuerStandService_GetDevInfo_Req req;
- CardIssuerStandService_GetDevInfo_Ans ans;
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->GetDevInfo(req, ans, 10000);
- if (eErr == Error_Succeed)
- {
- bCI = true;
- count++;
- csCIType = ans.type;
- csCIModel = ans.model;
- csCIVersion = ans.version;
- ciState = ans.state;
- }
- else if (eErr == Error_DevNotAvailable || eErr == Error_NotInit)//兼容getdevinfo改造,转化打开失败异常情况
- {
- bCI = true;
- count++;
- csCIType = "";
- csCIModel = "";
- csCIVersion = "";
- ciState = 0;
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("GetDevInfo, CardIssuerStand GetDevInfo failed return:%d", eErr);
- }
- }
- else {
- CardIssuerStoreService_GetDevInfo_Req req;
- CardIssuerStoreService_GetDevInfo_Ans ans;
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->GetDevInfo(req, ans, 10000);
- if (eErr == Error_Succeed)
- {
- bCI = true;
- count++;
- csCIType = ans.type;
- csCIModel = ans.model;
- csCIVersion = ans.version;
- ciState = ans.state;
- }
- else if (eErr == Error_DevNotAvailable || eErr == Error_NotInit)//兼容getdevinfo改造,转化打开失败异常情况
- {
- bCI = true;
- count++;
- csCIType = "";
- csCIModel = "";
- csCIVersion = "";
- ciState = 0;
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("GetDevInfo, CardIssuerStore GetDevInfo failed return:%d", eErr);
- }
- }
- }
- if (IsTheEntity(ctx->Req.module, Module_ContactlessCard) && IsContactlessCardSessionOK())
- {
- ContactlessCardService_GetDevInfo_Req req;
- ContactlessCardService_GetDevInfo_Ans ans;
- eErr = (*m_pContactless)(EntityResource::getLink().upgradeLink())->GetDevInfo(req, ans, 10000);
- if (eErr == Error_Succeed)
- {
- bCC = true;
- count++;
- csCCType = ans.type;
- csCCModel = ans.model;
- csCCVersion = ans.version;
- ccState = ans.state;
- }
- else if (eErr == Error_DevNotAvailable || eErr == Error_NotInit)//兼容getdevinfo改造,转化打开失败异常情况
- {
- bCC = true;
- count++;
- csCCType = "";
- csCCModel = "";
- csCCVersion = "";
- ccState = 0;
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("GetDevInfo, ContactlessCard GetDevInfo failed return:%d", eErr);
- }
- }
- ctx->Ans.ModuleNum = count;
- ctx->Ans.ModuleSN.Init(count);
- ctx->Ans.type.Init(count);
- ctx->Ans.model.Init(count);
- ctx->Ans.version.Init(count);
- ctx->Ans.state.Init(count);
- int index = 0;
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("count:%d,index:%d,%d,%d,%d",count,index,bCI,bCC,bCS);
- if (bCI)
- {
- ctx->Ans.ModuleSN[index] = Module_CardIssuer;
- ctx->Ans.type[index] = csCIType;
- ctx->Ans.model[index] = csCIModel;
- ctx->Ans.version[index] = csCIVersion;
- ctx->Ans.state[index] = ciState;
- if (!IsCardIssuerStore()) {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("CardIssuerStand, type:%s, model:%s, version:%s, state:%d",
- csCIType.GetData(), csCIModel.GetData(), csCIVersion.GetData(), ciState);
- }
- else {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("CardIssuerStore, type:%s, model:%s, version:%s, state:%d",
- csCIType.GetData(), csCIModel.GetData(), csCIVersion.GetData(), ciState);
- }
- index++;
- }
- if (bCC)
- {
- ctx->Ans.ModuleSN[index] = Module_ContactlessCard;
- ctx->Ans.type[index] = csCCType;
- ctx->Ans.model[index] = csCCModel;
- ctx->Ans.version[index] = csCCVersion;
- ctx->Ans.state[index] = ccState;
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("ContactlessCard, type:%s, model:%s, version:%s, state:%d",
- csCCType.GetData(), csCCModel.GetData(), csCCVersion.GetData(), ccState);
- index++;
- }
- ctx->Answer(Error_Succeed);
- return 0;
- }
- int CCardReadAdapterFSM::GetMaterialCount(SpReqAnsContext<CardReadAdapterService_GetMaterialCount_Req, CardReadAdapterService_GetMaterialCount_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- DWORD dwUsrErrCode = 0;
- if (IsCardIssuerSessionOK())
- {
- if (!IsCardIssuerStore()) {
- CardIssuerStandService_GetMaterialCountEx_Req req;
- CardIssuerStandService_GetMaterialCountEx_Ans ans;
- req.GetHopper.Copy(ctx->Req.GetHopper);
- req.reserved1.Copy(ctx->Req.reserved1);
- req.reserved2.Copy(ctx->Req.reserved2);
- ErrorCodeEnum eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->GetMaterialCountEx(req, ans, 10000, dwUsrErrCode);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.captured = ans.captured;
- ctx->Ans.hasHopper.Copy(ans.hasHopper);
- ctx->Ans.CardBoxNo.Copy(ans.CardBoxNo);
- ctx->Ans.PsbCode.Copy(ans.PsbCode);
- ctx->Ans.PsbName.Copy(ans.PsbName);
- ctx->Ans.Maintainer.Copy(ans.Maintainer);
- ctx->Ans.CardInit.Copy(ans.CardInit);
- ctx->Ans.CardPercent.Copy(ans.CardPercent);
- ctx->Ans.remains.Copy(ans.remains);
- ctx->Ans.issued.Copy(ans.issued);
- ctx->Ans.mixed.Copy(ans.mixed);
- ctx->Ans.MaintainTime.Copy(ans.MaintainTime);
- ctx->Ans.reserved1.Copy(ans.reserved1);
- ctx->Ans.reserved2.Copy(ans.reserved2);
- ctx->Answer(Error_Succeed);
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("GetMaterialCount, CardIssuerStand GetMaterialCountEx failed return:%d", eErr);
- ctx->Answer(Error_Unexpect, dwUsrErrCode);
- }
- }
- else {
- CardIssuerStoreService_GetMaterialCountEx_Req req;
- CardIssuerStoreService_GetMaterialCountEx_Ans ans;
- req.GetHopper.Copy(ctx->Req.GetHopper);
- req.reserved1.Copy(ctx->Req.reserved1);
- req.reserved2.Copy(ctx->Req.reserved2);
- ErrorCodeEnum eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->GetMaterialCountEx(req, ans, 10000, dwUsrErrCode);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.captured = ans.captured;
- ctx->Ans.hasHopper.Copy(ans.hasHopper);
- ctx->Ans.CardBoxNo.Copy(ans.CardBoxNo);
- ctx->Ans.PsbCode.Copy(ans.PsbCode);
- ctx->Ans.PsbName.Copy(ans.PsbName);
- ctx->Ans.Maintainer.Copy(ans.Maintainer);
- ctx->Ans.CardInit.Copy(ans.CardInit);
- ctx->Ans.CardPercent.Copy(ans.CardPercent);
- ctx->Ans.remains.Copy(ans.remains);
- ctx->Ans.issued.Copy(ans.issued);
- ctx->Ans.mixed.Copy(ans.mixed);
- ctx->Ans.MaintainTime.Copy(ans.MaintainTime);
- ctx->Ans.reserved1.Copy(ans.reserved1);
- ctx->Ans.reserved2.Copy(ans.reserved2);
- ctx->Answer(Error_Succeed);
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("GetMaterialCount, CardIssuerStore GetMaterialCountEx failed return:%d", eErr);
- ctx->Answer(Error_Unexpect, dwUsrErrCode);
- }
- }
- }
- else
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("GetMaterialCountEx is err, session is not ok");
- ctx->Answer(Error_Unexpect);
- }
- return 0;
- }
- int CCardReadAdapterFSM::SetMaterialCount(SpReqAnsContext<CardReadAdapterService_SetMaterialCount_Req, CardReadAdapterService_SetMaterialCount_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- DWORD dwUsrErrCode = 0;
- if (IsCardIssuerSessionOK())
- {
- if (!IsCardIssuerStore()) {
- CardIssuerStandService_SetMaterialCountEx_Req req;
- CardIssuerStandService_SetMaterialCountEx_Ans ans;
- req.SetCaptured = ctx->Req.SetCaptured;
- req.captured = ctx->Req.captured;
- req.SetHopper.Copy(ctx->Req.SetHopper);
- req.CardBoxNo.Copy(ctx->Req.CardBoxNo);
- req.PsbCode.Copy(ctx->Req.PsbCode);
- req.PsbName.Copy(ctx->Req.PsbName);
- req.Maintainer.Copy(ctx->Req.Maintainer);
- req.MaintainTime.Copy(ctx->Req.MaintainTime);
- req.CardInit.Copy(ctx->Req.CardInit);
- req.CardPercent.Copy(ctx->Req.CardPercent);
- req.remains.Copy(ctx->Req.remains);
- req.issued.Copy(ctx->Req.issued);
- req.mixed.Copy(ctx->Req.mixed);
- req.reserved1.Copy(ctx->Req.reserved1);
- req.reserved2.Copy(ctx->Req.reserved2);
- ErrorCodeEnum eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->SetMaterialCountEx(req, ans, 10000, dwUsrErrCode);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.reserved1.Copy(ans.reserved1);
- ctx->Ans.reserved2.Copy(ans.reserved2);
- ctx->Answer(Error_Succeed);
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("SetMaterialCount, CardIssuerStand SetMaterialCountEx failed return:%d", eErr);
- ctx->Answer(Error_Unexpect, dwUsrErrCode);
- }
- }
- else {
- CardIssuerStoreService_SetMaterialCountEx_Req req;
- CardIssuerStoreService_SetMaterialCountEx_Ans ans;
- req.SetCaptured = ctx->Req.SetCaptured;
- req.captured = ctx->Req.captured;
- req.SetHopper.Copy(ctx->Req.SetHopper);
- req.CardBoxNo.Copy(ctx->Req.CardBoxNo);
- req.PsbCode.Copy(ctx->Req.PsbCode);
- req.PsbName.Copy(ctx->Req.PsbName);
- req.Maintainer.Copy(ctx->Req.Maintainer);
- req.MaintainTime.Copy(ctx->Req.MaintainTime);
- req.CardInit.Copy(ctx->Req.CardInit);
- req.CardPercent.Copy(ctx->Req.CardPercent);
- req.remains.Copy(ctx->Req.remains);
- req.issued.Copy(ctx->Req.issued);
- req.mixed.Copy(ctx->Req.mixed);
- req.reserved1.Copy(ctx->Req.reserved1);
- req.reserved2.Copy(ctx->Req.reserved2);
- ErrorCodeEnum eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->SetMaterialCountEx(req, ans, 10000, dwUsrErrCode);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.reserved1.Copy(ans.reserved1);
- ctx->Ans.reserved2.Copy(ans.reserved2);
- ctx->Answer(Error_Succeed);
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("SetMaterialCount, CardIssuerStore SetMaterialCountEx failed return:%d", eErr);
- ctx->Answer(Error_Unexpect, dwUsrErrCode);
- }
- }
-
- }
- else
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("SetMaterialCountEx is err, session is not ok");
- ctx->Answer(Error_Unexpect);
- }
- return 0;
- }
- int CCardReadAdapterFSM::OpenSafeLock(SpReqAnsContext<CardReadAdapterService_OpenSafeLock_Req, CardReadAdapterService_OpenSafeLock_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("OpenSafeLock is not deal with");
- ctx->Answer(Error_Unexpect);
- return 0;
- }
- int CCardReadAdapterFSM::MagTransferInit(SpReqAnsContext<CardReadAdapterService_MagTransferInit_Req, CardReadAdapterService_MagTransferInit_Ans>::Pointer ctx)
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Entity CardSwiper is not ok.");
- ctx->Answer(Error_Unexpect);
- return 0;
- }
- int CCardReadAdapterFSM::QueryConnInfo(SpReqAnsContext<CardReadAdapterService_QueryConnInfo_Req, CardReadAdapterService_QueryConnInfo_Ans>::Pointer ctx)
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Entity CardSwiper is not ok.");
- ctx->Answer(Error_Unexpect);
- return 0;
- }
- void CCardReadAdapterFSM::DoExit()
- {
- ErrorCodeEnum eErr = Error_Unexpect;
- if (IsCardIssuerSessionOK())
- {
- if (!IsCardIssuerStore()) {
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->Exit();
- }
- else {
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->Exit();
- }
-
- }
- if (IsContactlessCardSessionOK())
- {
- eErr = (*m_pContactless)(EntityResource::getLink().upgradeLink())->Exit();
- }
- }
- void CCardReadAdapterFSM::BroadcastReadICing(int status)
- {
- ReadICing evt;
- evt.status = status;
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("BroadcastReadICing, status:%d", status);
- SpSendBroadcast(GetEntityBase()->GetFunction(), SP_MSG_OF(ReadICing), SP_MSG_SIG_OF(ReadICing), evt);
- }
- int CCardReadAdapterFSM::SAMICCommand(SpReqAnsContext<CardReadAdapterService_SAMICCommand_Req, CardReadAdapterService_SAMICCommand_Ans>::Pointer ctx)
- {
- if (IsTheEntity(ctx->Req.module, Module_CardIssuer) && IsCardIssuerSessionOK())
- {
- if (!IsCardIssuerStore()) {
- ErrorCodeEnum eErr = Error_Unexpect;
- CardIssuerStandService_SAMICCommand_Req req;
- CardIssuerStandService_SAMICCommand_Ans ans;
- req.cmdType = ctx->Req.cmdType;
- req.param1.Copy(ctx->Req.param1);
- req.param2.Copy(ctx->Req.param2);
- req.reserved1.Copy(ctx->Req.reserved1);
- req.reserved2.Copy(ctx->Req.reserved2);
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->SAMICCommand(req, ans, 50000);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.ret1.Copy(ans.ret1);
- ctx->Ans.ret2.Copy(ans.ret2);
- ctx->Ans.reserved1.Copy(ans.reserved1);
- ctx->Ans.reserved2.Copy(ans.reserved2);
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("SAMICCommand, CardIssuerStand SAMICCommand failed return:%d", eErr);
- }
- ctx->Answer(eErr);
- return 0;
- }
- else {
- ErrorCodeEnum eErr = Error_Unexpect;
- CardIssuerStoreService_SAMICCommand_Req req;
- CardIssuerStoreService_SAMICCommand_Ans ans;
- req.cmdType = ctx->Req.cmdType;
- req.param1.Copy(ctx->Req.param1);
- req.param2.Copy(ctx->Req.param2);
- req.reserved1.Copy(ctx->Req.reserved1);
- req.reserved2.Copy(ctx->Req.reserved2);
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->SAMICCommand(req, ans, 50000);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.ret1.Copy(ans.ret1);
- ctx->Ans.ret2.Copy(ans.ret2);
- ctx->Ans.reserved1.Copy(ans.reserved1);
- ctx->Ans.reserved2.Copy(ans.reserved2);
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("SAMICCommand, CardIssuerStore SAMICCommand failed return:%d", eErr);
- }
- ctx->Answer(eErr);
- return 0;
- }
- }
- else
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("SAMICCommand param error or connection is failed:(module)%d", ctx->Req.module);
- ctx->Answer(Error_Param);
- return 1;
- }
- }
- int CCardReadAdapterFSM::QueryPrinterStatus(SpReqAnsContext<CardReadAdapterService_QueryPrinterStatus_Req, CardReadAdapterService_QueryPrinterStatus_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("QueryPrinterStatus is not deal with");
- ctx->Answer(Error_Unexpect);
- return 0;
- }
- int CCardReadAdapterFSM::Print(SpReqAnsContext<CardReadAdapterService_Print_Req, CardReadAdapterService_Print_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Print is not deal with");
- ctx->Answer(Error_Unexpect);
- return 0;
- }
- int CCardReadAdapterFSM::QuerySCIList(SpReqAnsContext<CardReadAdapterService_QuerySCIList_Req, CardReadAdapterService_QuerySCIList_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- DWORD dwUsrErrCode = 0;
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("QuerySCIList is not deal with");
- ctx->Answer(Error_Unexpect);
- return 0;
- }
- int CCardReadAdapterFSM::BindSCI(SpReqAnsContext<CardReadAdapterService_BindSCI_Req, CardReadAdapterService_BindSCI_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- DWORD dwUsrErrCode = 0;
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("BindSCI is not deal with");
- ctx->Answer(Error_Unexpect);
- return 0;
- }
- int CCardReadAdapterFSM::PreOnlineOnStore(SpReqAnsContext<CardReadAdapterService_PreOnlineOnStore_Req, CardReadAdapterService_PreOnlineOnStore_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- //oilyang@20230525 to call heartbeat directly
- if (!CheckHBSessionOrToConnect())
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("While calling to PreOnlineOnStore, connect to HeartBeat failed.");
- ctx->Answer(Error_DevNotAvailable);
- return 0;
- }
- m_crossCtx = ctx;
- ErrorCodeEnum eErr = Error_Unexpect;
- CSimpleStringA errMsg(true);
- m_ullCrossStart = GetTickCountRVC();
- if (m_pHBClient != NULL)
- {
- HeartBeatService_CardActive_Req req;
- HeartBeatService_CardActive_Ans ans;
- req.type = 0;
- req.account = ctx->Req.account;
- req.term = ctx->Req.termNo;
- req.data = ctx->Req.businessData;
- req.slot = ctx->Req.slot;
- errMsg = CSimpleStringA::Format("<PreOnlineOnStore>, send CardActive, termNo:%s, slot:%d", req.term.GetData(), req.slot);
- LogWarn(Severity_Low, Error_Unexpect, CardIssuer_UserErrorCode_PreOnline_Send_CardActive, errMsg.GetData());
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode("QLR040220327")("to call heartbeat CardActive");
- eErr = (*m_pHBClient)(EntityResource::getLink().upgradeLink())->CardActive(req, ans, 6000);
- if (eErr == Error_Succeed)
- {
- m_bCardActiveNotify = false;
- WaitCardActiveTask* pTask = new WaitCardActiveTask(this);
- GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
- }
- else
- {
- errMsg = CSimpleStringA::Format("CardActive Result(termNo:%s, slot:%d):%d(0x%x)", req.term.GetData(), req.slot, eErr, eErr);
- LogWarn(Severity_Middle, Error_Unexpect, CardIssuer_UserErrorCode_PreOnline_Recv_CardActive, errMsg.GetData());
- }
- }
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("have send heartbeat CardActive");
- return 1;//维持s3状态,直到收到返回或超时
- }
- int CCardReadAdapterFSM::NotifyPreonline(SpReqAnsContext<CardReadAdapterService_NotifyPreonline_Req, CardReadAdapterService_NotifyPreonline_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- UINT64 crossEnd = GetTickCountRVC();
- //? ? ? 为什么是110s,重试?从生产实际来看,在25s到40s之间,大部分在30s左右,需要和前端(65s)一致,改成60s oilyang@20221019
- //in 110 second
- if (m_crossCtx != NULL)
- {
- if ((crossEnd - m_ullCrossStart) < 60 * 1000)
- {
- m_bCardActiveNotify = true;
- m_crossCtx->Ans.cardPos = ctx->Req.cardPos;
- m_crossCtx->Ans.findCard = ctx->Req.findCard;
- m_crossCtx->Ans.result = ctx->Req.data;
- CSimpleStringA outParam = CSimpleStringA::Format("NotifyPreOnline, cardPos:%d, findCard:%d, errCode:%d, userErrCode:%d", ctx->Req.cardPos, ctx->Req.findCard, ctx->Req.errCode, ctx->Req.reserved1[0]);
- LogWarn(Severity_Low, Error_Unexpect, CardIssuer_UserErrorCode_NotifyPreOnline_ParamInfo, outParam.GetData());
- //oilyang@20230629
- //compare with the "ctx->Req.errCode" or "ctx->Req.reserved1[0]" which is stand for UserErrorCode from CardStore
- if (ctx->Req.errCode == Error_Duplication || ctx->Req.reserved1[0] == CardReadAdapter_UserErrorCode_CardIssuer_Is_Working
- || ctx->Req.reserved1[0] == CardIssuer_UserErrorCode_CardActive_CardStore_Issuing
- || ctx->Req.reserved1[0] == CardIssuerStore_UserErrorCode_CardActive_CardStore_Issuing)
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode("QLR040220327").setResultCode("RTA230Q")("卡库正在使用中");
- LogWarn(Severity_Low, Error_Unexpect, CardReadAdapter_UserErrorCode_CardIssuer_Is_Working, "卡库正在使用中");
- m_crossCtx->Answer(Error_DevNotAvailable, CardIssuer_UserErrorCode_DupCallPreOnline_WhileInWorking);
- }
- else if (ctx->Req.errCode == Error_TimeOut)//CardStore process cost too long!
- {
- //DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode("QLR040220327").setResultCode("RTA230W")("跨机时卡库处理耗时过长");
- //LogError(Severity_Middle, Error_Unexpect, CardIssuer_UserErrorCode_CardStore_Reply_TooLong, "跨机时卡库处理耗时过长");
- m_crossCtx->Answer(Error_Unexpect, CardIssuer_UserErrorCode_CardStore_Reply_TooLong);
- }
- else if (ctx->Req.errCode == Error_NotExist)//heartbeat service can't find the dest terminal
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode("QLR040220327").setResultCode("RTA230Y")("跨机时卡库不在线");
- LogWarn(Severity_Middle, Error_Unexpect, CardIssuer_UserErrorCode_CardActive_CardStore_OffLine, "跨机时卡库不在线");
- m_crossCtx->Answer(Error_DevNotAvailable, CardIssuer_UserErrorCode_CardActive_CardStore_OffLine);
- }
- else if (ctx->Req.reserved1[0] == CardIssuer_UserErrorCode_DevOpen_Failed || ctx->Req.reserved1[0] == CardIssuerStore_UserErrorCode_DevOpen_Failed)
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode("QLR040220327").setResultCode("RTA2R04")("卡库卡机未成功打开");
- LogWarn(Severity_Middle, Error_Unexpect, CardReadAdapter_UserErrorCode_CardIssuerStore_DevOpen_Failed, "卡库卡机未成功打开");
- m_crossCtx->Answer(Error_DevNotAvailable, CardReadAdapter_UserErrorCode_CardIssuerStore_DevOpen_Failed);
- }
- else
- {
- if (ctx->Req.errCode != Error_Succeed)
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode("QLR040220327")("卡库异常:Req.errCode:%d, userErrCode:%d(0x%x)", ctx->Req.errCode, ctx->Req.reserved1[0], ctx->Req.reserved1[0]);
- LogWarn(Severity_Middle, Error_Unexpect, CardReadAdapter_UserErrorCode_CardActive_Unexpect,
- CSimpleStringA::Format("卡库异常:Req.errCode:%d, userErrCode:%d(0x%x)", ctx->Req.errCode, ctx->Req.reserved1[0], ctx->Req.reserved1[0]));
- }
- m_crossCtx->Answer((ErrorCodeEnum)ctx->Req.errCode, MapErrorCodeWhileCallStore(ctx->Req.reserved1[0]));
- }
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode("QLR040220327").setResultCode("RTA2312")("超时后,才收到卡库返回");
- LogWarn(Severity_Middle, Error_Unexpect, CardIssuer_UserErrorCode_NotifyPreonline_Wait_TooLong, "CardStore return after timeout.");
- }
- m_crossCtx = NULL;
- }
- ctx->Answer(Error_Succeed);
- return 0;
- }
- int CCardReadAdapterFSM::QueryCardInfoOnStore(SpReqAnsContext<CardReadAdapterService_QueryCardInfoOnStore_Req, CardReadAdapterService_QueryCardInfoOnStore_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- if (IsCardIssuerSessionOK())
- {
- if (!IsCardIssuerStore()) {
- DWORD dwUserErrorCode = 0;
- ErrorCodeEnum eErr = Error_Unexpect;
- CardIssuerStandService_QueryCardInfoOnStore_Req req;
- CardIssuerStandService_QueryCardInfoOnStore_Ans ans;
- req.reserved1.Copy(ctx->Req.reserved1);
- req.reserved2.Copy(ctx->Req.reserved2);
- req.reserved3.Copy(ctx->Req.reserved3);
- req.reserved4.Copy(ctx->Req.reserved4);
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->QueryCardInfoOnStore(req, ans, INT_MAX / 2 - 5000, dwUserErrorCode);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.cardPos = ans.cardPos;
- ctx->Ans.findCard = ans.findCard;
- ctx->Ans.reserved1.Copy(ans.reserved1);
- ctx->Ans.reserved2.Copy(ans.reserved2);
- ctx->Ans.reserved3.Copy(ans.reserved3);
- ctx->Ans.reserved4.Copy(ans.reserved4);
- ctx->Answer(Error_Succeed);
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("QueryCardInfoOnStore, CardIssuerStand QueryCardInfoOnStore failed return:%d", eErr);
- ctx->Answer(eErr, dwUserErrorCode);
- }
- }
- else {
- DWORD dwUserErrorCode = 0;
- ErrorCodeEnum eErr = Error_Unexpect;
- CardIssuerStoreService_QueryCardInfoOnStore_Req req;
- CardIssuerStoreService_QueryCardInfoOnStore_Ans ans;
- req.reserved1.Copy(ctx->Req.reserved1);
- req.reserved2.Copy(ctx->Req.reserved2);
- req.reserved3.Copy(ctx->Req.reserved3);
- req.reserved4.Copy(ctx->Req.reserved4);
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->QueryCardInfoOnStore(req, ans, INT_MAX / 2 - 5000, dwUserErrorCode);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.cardPos = ans.cardPos;
- ctx->Ans.findCard = ans.findCard;
- ctx->Ans.reserved1.Copy(ans.reserved1);
- ctx->Ans.reserved2.Copy(ans.reserved2);
- ctx->Ans.reserved3.Copy(ans.reserved3);
- ctx->Ans.reserved4.Copy(ans.reserved4);
- ctx->Answer(Error_Succeed);
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("QueryCardInfoOnStore, CardIssuerStore QueryCardInfoOnStore failed return:%d", eErr);
- ctx->Answer(eErr, dwUserErrorCode);
- }
- }
-
- }
- else
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("QueryCardInfoOnStore is err, session is not ok");
- ctx->Answer(Error_DevNotAvailable, CardReadAdapter_UserErrorCode_PreOnline_CardIssuer_Not_Ok);
- }
- return 0;
- }
- int CCardReadAdapterFSM::GetAddCardInfo(SpReqAnsContext<CardReadAdapterService_GetAddCardInfo_Req, CardReadAdapterService_GetAddCardInfo_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- if (IsCardIssuerSessionOK())
- {
- if (IsCardIssuerStore()) {
- DWORD dwUserErrorCode = 0;
- ErrorCodeEnum eErr = Error_Unexpect;
- CardIssuerStoreService_GetAddCardInfo_Req req;
- CardIssuerStoreService_GetAddCardInfo_Ans ans;
- req.isSync = ctx->Req.isSync;
- req.reserved1.Copy(ctx->Req.reserved1);
- req.reserved2.Copy(ctx->Req.reserved2);
- req.reserved3.Copy(ctx->Req.reserved3);
- req.reserved4.Copy(ctx->Req.reserved4);
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->GetAddCardInfo(req, ans, 10000, dwUserErrorCode);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.account = ans.account;
- ctx->Ans.cardSerial = ans.cardSerial;
- ctx->Ans.count = ans.count;
- ctx->Ans.slot = ans.slot;
- ctx->Ans.reserved1.Copy(ans.reserved1);
- ctx->Ans.reserved2.Copy(ans.reserved2);
- ctx->Ans.reserved3.Copy(ans.reserved3);
- ctx->Ans.reserved4.Copy(ans.reserved4);
- ctx->Answer(Error_Succeed);
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("GetAddCardInfo, CardIssuerStore GetAddCardInfo failed return:%d,%x", eErr, dwUserErrorCode);
- ctx->Answer(eErr, dwUserErrorCode);
- }
- }
- }
- else
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("GetAddCardInfo is err, session is not ok");
- ctx->Answer(Error_DevNotAvailable, CardReadAdapter_UserErrorCode_PreOnline_CardIssuer_Not_Ok);
- }
- return 0;
- }
- int CCardReadAdapterFSM::Test1(SpReqAnsContext<CardReadAdapterService_Test1_Req, CardReadAdapterService_Test1_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- ctx->Answer(Error_Succeed);
- return 0;
- }
- int CCardReadAdapterFSM::Test2(SpReqAnsContext<CardReadAdapterService_Test2_Req, CardReadAdapterService_Test2_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- ctx->Answer(Error_Succeed);
- return 0;
- }
- void CCardReadAdapterFSM::SelfTest(EntityTestEnum eTestType, CSmartPointer<ITransactionContext> pTransactionContext)
- {
- //for simple
- pTransactionContext->SendAnswer(m_testResult);
- }
- int CCardReadAdapterFSM::CrossTermCall(SpReqAnsContext<CardReadAdapterService_CrossTermCall_Req, CardReadAdapterService_CrossTermCall_Ans>::Pointer cctx)
- {
- ErrorCodeEnum eErr = Error_Deprecated;
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("CrossTermCall,type:%x", cctx->Req.type);
- cctx->Answer((ErrorCodeEnum)eErr);
- return 0;
- }
- void CCardReadAdapterFSM::CrossTermInvokeInfo(SpOnewayCallContext<CardReadAdapterService_CrossTermInvokeInfo_Info>::Pointer ctx)
- {
- LOG_FUNCTION();
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("entity sn:%x,type:%d,errcode:%x", ctx->Info.nEntityID, ctx->Info.type, ctx->Info.result);
- }
- int CCardReadAdapterFSM::LocalCallHeartBeat(int method, CBlob &bbSend,bool bTwoWay)
- {
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("method id(type):%d", method);
- HeartBeatService_ClientBase* pClient = new HeartBeatService_ClientBase(GetEntityBase());
- if (pClient == NULL)
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("create HeartBeat client failed.GetLastError:%d", GetLastError());
- return -1;
- }
- ErrorCodeEnum eErr = Error_Unexpect;
- eErr = pClient->Connect();
- if (eErr != Error_Succeed)
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("client connect to HeartBeat failed:%x", eErr);
- return -1;
- }
- HeartBeatService_CrossTermCall_Req req;
- HeartBeatService_CrossTermCall_Ans ans;
- req.nEntityID = 0x21b;
- req.isTwoWay = bTwoWay;
- req.fromTerminalNo = m_terminalNo;
- GetAttachedTerminal(req.toTerminalNo);
- //req.toTerminalNo = "7717715004";
- req.param1 = "";
- req.param2 = "";
- req.paramX = bbSend;
- req.type = method;
- eErr = (*pClient)(EntityResource::getLink().upgradeLink())->CrossTermCall(req, ans, 20000);
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("CrossTermCall to HeartBeat from %s to %s, result:%x",
- req.fromTerminalNo.GetData(), req.toTerminalNo.GetData(), eErr);
- return 0;
- }
- bool CCardReadAdapterFSM::GetAttachedTerminal(CSimpleStringA &csTerm)
- {
- return (Error_Succeed == GetEntityBase()->GetFunction()->GetSysVar("AttachedTerminal", csTerm));
- }
- void CCardReadAdapterFSM::CancelReadForEntity(ModuleType eModule)
- {
- LOG_FUNCTION();
- if (IsTheEntity(eModule, Module_CardIssuer) && IsCardIssuerSessionOK())
- {
- if (!IsCardIssuerStore()) {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Set cancel read by ContactlessCard flag of CardIssuerStand.");
- CardIssuerStandService_SetSomeFlag_Req req;
- CardIssuerStandService_SetSomeFlag_Ans ans;
- req.IssueBusiness = 3;
- (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->SetSomeFlag(req, ans, 5000);
- (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->CancelInsert();
- }
- else {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Set cancel read by ContactlessCard flag of CardIssuerStore.");
- CardIssuerStoreService_SetSomeFlag_Req req;
- CardIssuerStoreService_SetSomeFlag_Ans ans;
- req.IssueBusiness = 3;
- (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->SetSomeFlag(req, ans, 5000);
- (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->CancelInsert();
- }
- }
- if (IsTheEntity(eModule, Module_ContactlessCard) && IsContactlessCardSessionOK())
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Cancel read by CardSwiper of ContactlessCard.");
- (*m_pContactless)(EntityResource::getLink().upgradeLink())->CancelInsert();
- }
- }
- int CCardReadAdapterFSM::PrintCardIm(SpReqAnsContext<CardReadAdapterService_PrintCardImmediately_Req, CardReadAdapterService_PrintCardImmediately_Ans>::Pointer ctx)
- {
- LOG_FUNCTION();
- if (IsCardIssuerSessionOK())
- {
- if (IsCardIssuerStore()){
- ErrorCodeEnum eErr = Error_Unexpect;
- CardIssuerStoreService_PrintCardImmediately_Req req;
- CardIssuerStoreService_PrintCardImmediately_Ans ans;
- req.formFile = ctx->Req.formFile;
- req.printData = ctx->Req.printData;
- req.reserved1.Copy(ctx->Req.reserved1);
- req.reserved2.Copy(ctx->Req.reserved2);
- req.reserved3.Copy(ctx->Req.reserved3);
- req.reserved4.Copy(ctx->Req.reserved4);
- int timeout = 60000;
- if (ctx->Req.reserved1.GetCount() > 0 && ctx->Req.reserved1[0] > 50000 && ctx->Req.reserved1[0] < 200000)
- timeout = ctx->Req.reserved1[0];
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("PrintCardIm, timeout:%d", timeout);
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->PrintCardImmediately(req, ans, timeout);
- if (eErr == Error_Succeed)
- {
- ctx->Ans.ret = ans.ret;
- ctx->Ans.reserved1.Copy(ans.reserved1);
- ctx->Ans.reserved2.Copy(ans.reserved2);
- ctx->Ans.reserved3.Copy(ans.reserved3);
- ctx->Ans.reserved4.Copy(ans.reserved4);
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("PrintCardImmediately, CardIssuerStore PrintCardImmediately failed return:%d", eErr);
- }
- ctx->Answer(eErr);
- return 0;
- }
- }
- else
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("PrintCardIm is err, session is not ok");
- ctx->Answer(Error_Param);
- return 1;
- }
- }
- int CCardReadAdapterFSM::QueryCIStatus(SpReqAnsContext<CardReadAdapterService_QueryCIStatus_Req, CardReadAdapterService_QueryCIStatus_Ans>::Pointer ctx)
- {
- if (IsCardIssuerSessionOK())
- {
- if (!IsCardIssuerStore()) {
- ErrorCodeEnum eErr = Error_Unexpect;
- CardIssuerStandService_QueryCIStatus_Req req;
- CardIssuerStandService_QueryCIStatus_Ans ans;
- req.reserved1.Copy(ctx->Req.reserved1);
- req.reserved2.Copy(ctx->Req.reserved2);
- req.reserved3.Copy(ctx->Req.reserved3);
- req.reserved4.Copy(ctx->Req.reserved4);
- DWORD dwUsrErrCode = 0;
- eErr = (*m_pCardIssuer)(EntityResource::getLink().upgradeLink())->QueryCIStatus(req, ans, 5000, dwUsrErrCode);
- if (eErr == Error_Succeed)
- {
- if (ans.reserved1.GetCount() > 0)
- ctx->Ans.reserved1.Copy(ans.reserved1);
- if (ans.reserved2.GetCount() > 0)
- ctx->Ans.reserved2.Copy(ans.reserved2);
- if (ans.reserved3.GetCount() > 0)
- ctx->Ans.reserved3.Copy(ans.reserved3);
- if (ans.reserved4.GetCount() > 0)
- ctx->Ans.reserved4.Copy(ans.reserved4);
- ctx->Ans.retainBin = ans.retainBin;
- if (ans.hopperNo.GetCount() > 0)
- {
- ctx->Ans.hopperNo.Copy(ans.hopperNo);
- ctx->Ans.hopperStatus.Copy(ans.hopperStatus);
- }
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)(CSimpleStringA::Format("CardIssuerStand QueryCIStatus failed return:%d", eErr));
- }
- ctx->Answer(eErr, dwUsrErrCode);
- return 0;
- }
- else {
- ErrorCodeEnum eErr = Error_Unexpect;
- CardIssuerStoreService_QueryCIStatus_Req req;
- CardIssuerStoreService_QueryCIStatus_Ans ans;
- req.reserved1.Copy(ctx->Req.reserved1);
- req.reserved2.Copy(ctx->Req.reserved2);
- req.reserved3.Copy(ctx->Req.reserved3);
- req.reserved4.Copy(ctx->Req.reserved4);
- DWORD dwUsrErrCode = 0;
- eErr = (*m_pCardIssuerStore)(EntityResource::getLink().upgradeLink())->QueryCIStatus(req, ans, 5000, dwUsrErrCode);
- if (eErr == Error_Succeed)
- {
- if (ans.reserved1.GetCount() > 0)
- ctx->Ans.reserved1.Copy(ans.reserved1);
- if (ans.reserved2.GetCount() > 0)
- ctx->Ans.reserved2.Copy(ans.reserved2);
- if (ans.reserved3.GetCount() > 0)
- ctx->Ans.reserved3.Copy(ans.reserved3);
- if (ans.reserved4.GetCount() > 0)
- ctx->Ans.reserved4.Copy(ans.reserved4);
- ctx->Ans.retainBin = ans.retainBin;
- if (ans.hopperNo.GetCount() > 0)
- {
- ctx->Ans.hopperNo.Copy(ans.hopperNo);
- ctx->Ans.hopperStatus.Copy(ans.hopperStatus);
- }
- }
- else {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)(CSimpleStringA::Format("CardIssuerStore QueryCIStatus failed return:%d", eErr));
- }
- ctx->Answer(eErr, dwUsrErrCode);
- return 0;
- }
- }
- return 0;
- }
- void CCardReadAdapterFSM::WaitCardActive()
- {
- while (1)
- {
- if (m_bCardActiveNotify)
- break;
- UINT64 crossEnd = GetTickCountRVC();
- if ((crossEnd - m_ullCrossStart) < 62 * 1000)
- Sleep(1000);
- else {
- if (m_crossCtx != NULL)
- {
- FSMEvent* e = new FSMEvent(USER_EVT_PREONLINE_ON_STORE_FINISHED);
- PostEventFIFO(e);
- DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_USER).setLogCode("QLR040220327").setResultCode("RTA2R03")("跨机激活未收到返回,请确认卡库或服务是否正常");
- m_crossCtx->Answer(Error_TimeOut, CardReadAdapter_UserErrorCode_HBService_No_Return);
- LogError(Severity_Middle, Error_Unexpect, CardReadAdapter_UserErrorCode_HBService_No_Return, "CardActive havn't return in 60s");
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("record for HealthManager test 1792 to kill CardIsser");
- break;
- }
- }
- }
- }
- bool CCardReadAdapterFSM::CheckHBSessionOrToConnect()
- {
- if (m_pHBClient != NULL && !m_pHBClient->QuerySessionClosed())
- return true;
- else
- {
- ErrorCodeEnum eErr = Error_Unexpect;
- m_pHBClient = new HeartBeatService_ClientBase(GetEntityBase());
- if (m_pHBClient != NULL) {
- eErr = m_pHBClient->Connect();
- if (eErr != Error_Succeed)
- {
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("connect to HeartBeat failed:%d(0x%x)", eErr, eErr);
- return false;
- }
- else
- {
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("connect to HeartBeat suc.");
- return true;
- }
- }
- else
- return false;
- }
- }
|