PinPadFSM.cpp 57 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601
  1. #include "stdafx.h"
  2. #include "PinPadFSM.h"
  3. #include "PinPad_msg_g.h"
  4. #include "EventCode.h"
  5. #include "ModuleMix.h"
  6. #include <map>
  7. #include "RVCComm.h"
  8. #include "sm4.h"
  9. #include "publicFunExport.h"
  10. #include <fstream>
  11. #if defined(RVC_OS_LINUX)
  12. #include <thread>
  13. #include <chrono>
  14. #include <winpr/sysinfo.h>
  15. #endif
  16. using namespace std;
  17. const int PINPAD_INIT_TRIES = 3;
  18. const int PINPAD_ANY_INPUT_TIMEOUT = 100;
  19. const int MAX_PINPAD_INPUT_TIMEOUT = 60000;
  20. const int MAX_INPUT_TIMER_TIMEOUT = 600000;
  21. const int CurrentPasswordLen = 6;//according to guodan, we only use 6
  22. void CPinPadFSM::ToLogWarnInfoAboutTermCustom()
  23. {
  24. LOG_FUNCTION();
  25. std::map<std::string, std::string> termInfo;
  26. char* strFileHash = new char[128];
  27. memset(strFileHash, 0, 128);
  28. termInfo["keyType"] = _itoa(m_encryptkey, strFileHash,10);
  29. if (strFileHash != nullptr) {
  30. delete[] strFileHash;
  31. strFileHash = nullptr;
  32. }
  33. if (m_bSMLoaded)
  34. termInfo["SMKeyLoad"] = "true";
  35. else
  36. termInfo["SMKeyLoad"] = "false";
  37. ToLogWarnInfoAboutTermExtend(termInfo);
  38. }
  39. ErrorCodeEnum CPinPadFSM::OnInit()
  40. {
  41. LOG_FUNCTION();
  42. m_bOpening = true;
  43. CSystemStaticInfo sysInfo;
  44. m_csMachineType = m_csSite = m_terminalNo = "";
  45. GetEntityBase()->GetFunction()->GetSystemStaticInfo(sysInfo);
  46. m_csMachineType = sysInfo.strMachineType;
  47. m_csSite = sysInfo.strSite;
  48. m_terminalNo = sysInfo.strTerminalID;
  49. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("machineType:%s,site:%s,terminalNo:%s",
  50. (const char*)m_csMachineType, (const char*)m_csSite, (const char*)m_terminalNo);
  51. _beginthreadex(NULL,0,DoWork,(void*)this,0,NULL);
  52. return Error_Succeed;
  53. }
  54. ErrorCodeEnum CPinPadFSM::OnExit()
  55. {
  56. LOG_FUNCTION();
  57. m_bEntityExit = true;
  58. m_hInputConVar.Broadcast();
  59. ErrorCodeEnum eErr = Error_Succeed;
  60. if (m_hDevHelper != nullptr)
  61. {
  62. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  63. ErrorCodeEnum errClosePinPad = m_hDevHelper->StopInput();
  64. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  65. if (errClosePinPad != Error_Succeed)
  66. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::StopInput").setResultCode("RTA2614").setCostTime(m_ullEndTime - m_ullBeginTime)("OnExit:close pinpad(%d).", SpStrError(errClosePinPad));
  67. m_hDevHelper.TearDown();
  68. }
  69. return eErr;
  70. }
  71. void CPinPadFSM::s0_on_entry()
  72. {
  73. LOG_FUNCTION();
  74. FSMEvent *e = new FSMEvent(USER_EVT_INIT);
  75. PostEventFIFO(e);
  76. m_ullConnectCost = SP::Module::Comm::RVCGetTickCount();
  77. }
  78. void CPinPadFSM::s0_on_exit()
  79. {
  80. }
  81. unsigned int CPinPadFSM::s0_on_event(FSMEvent* evt)
  82. {
  83. LOG_FUNCTION();
  84. if (evt->iEvt == USER_EVT_INIT) {
  85. m_hInputConVar.Broadcast();
  86. evt->SetHandled();
  87. return 0;
  88. }else if (evt->iEvt == USER_EVT_QUIT) {
  89. evt->SetHandled();
  90. return 0;
  91. }
  92. return 0;
  93. }
  94. void CPinPadFSM::s1_on_entry()
  95. {
  96. LOG_FUNCTION();
  97. }
  98. void CPinPadFSM::s1_on_exit()
  99. {
  100. }
  101. unsigned int CPinPadFSM::s1_on_event(FSMEvent* evt)
  102. {
  103. LOG_FUNCTION();
  104. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s1 event %d",evt->iEvt);
  105. int ret = 0;
  106. if (evt->iEvt == USER_EVT_INITFINISHED) {
  107. evt->SetHandled();
  108. int err = evt->param1;
  109. if (err == 0)
  110. ret = 0;
  111. else
  112. ret = 1;
  113. //SetEvent(m_hInitEvt);
  114. return ret;
  115. }else if (evt->iEvt == USER_EVT_QUIT) {
  116. evt->SetHandled();
  117. return 0;
  118. }
  119. return 0;
  120. }
  121. //Idle
  122. void CPinPadFSM::s2_on_entry()
  123. {
  124. LOG_FUNCTION();
  125. m_eDevState = DEVICE_STATUS_NORMAL;
  126. }
  127. void CPinPadFSM::s2_on_exit()
  128. {
  129. }
  130. unsigned int CPinPadFSM::s2_on_event(FSMEvent* pEvt)
  131. {
  132. if (pEvt->iEvt != 1)
  133. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s2 %d,%d",pEvt->iEvt,pEvt->param1);
  134. switch(pEvt->iEvt)
  135. {
  136. case USER_EVT_GETINPUT_SM:
  137. {
  138. m_hInputConVar.Broadcast();
  139. pEvt->SetHandled();
  140. return 0;
  141. }
  142. case USER_EVT_GETINPUT_JS:
  143. {
  144. m_hInputConVar.Broadcast();
  145. pEvt->SetHandled();
  146. return 0;
  147. }
  148. case USER_EVT_LOADKEY_SM:
  149. {
  150. pEvt->SetHandled();
  151. m_bLoadKey = true;
  152. LoadKeySMTask* task = new LoadKeySMTask(this);
  153. LoadKeySMEvent* lke = dynamic_cast<LoadKeySMEvent*>(pEvt);
  154. task->ctx = lke->ctx;
  155. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  156. return 2;
  157. }
  158. case USER_EVT_ENCRYPT_SM:
  159. {
  160. pEvt->SetHandled();
  161. m_bEncrypt = true;
  162. EncryptSMTask* task = new EncryptSMTask(this);
  163. EncryptSMEvent* ee = dynamic_cast<EncryptSMEvent*>(pEvt);
  164. task->ctx = ee->ctx;
  165. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  166. return 2;
  167. }
  168. case USER_EVT_GET_CHECKCODE:
  169. {
  170. pEvt->SetHandled();
  171. GetCheckCodeTask* task = new GetCheckCodeTask(this);
  172. GetCheckCodeEvent* gcce = dynamic_cast<GetCheckCodeEvent*>(pEvt);
  173. task->ctx = gcce->ctx;
  174. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  175. return 0;
  176. }
  177. case USER_EVT_QUIT:
  178. pEvt->SetHandled();
  179. break;
  180. default:
  181. break;
  182. }
  183. return 1;
  184. }
  185. //Input
  186. void CPinPadFSM::s3_on_entry()
  187. {
  188. LOG_FUNCTION();
  189. }
  190. void CPinPadFSM::s3_on_exit()
  191. {
  192. LOG_FUNCTION();
  193. }
  194. unsigned int CPinPadFSM::s3_on_event(FSMEvent* evt)
  195. {
  196. LOG_FUNCTION();
  197. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s3 event %d",evt->iEvt);
  198. switch(evt->iEvt)
  199. {
  200. case USER_EVT_GETINPUT_SM_FINISHED:
  201. evt->SetHandled();
  202. break;
  203. case USER_EVT_GETINPUT_JS_FINISHED:
  204. evt->SetHandled();
  205. break;
  206. case USER_EVT_INPUTCANCEL:
  207. evt->SetHandled();
  208. m_bFrontCancel = true;
  209. break;
  210. case USER_EVT_INPUTWAITINGMORE:
  211. evt->SetHandled();
  212. m_bWaitingMore = true;
  213. break;
  214. case USER_EVT_EXIT:
  215. SetExitFlag();
  216. break;
  217. case USER_EVT_QUIT:
  218. evt->SetHandled();
  219. break;
  220. default:
  221. break;
  222. }
  223. return 0;
  224. }
  225. //AccessAuth
  226. void CPinPadFSM::s4_on_entry()
  227. {
  228. LOG_FUNCTION();
  229. }
  230. void CPinPadFSM::s4_on_exit()
  231. {
  232. LOG_FUNCTION();
  233. }
  234. unsigned int CPinPadFSM::s4_on_event(FSMEvent* pEvt)
  235. {
  236. switch(pEvt->iEvt)
  237. {
  238. case USER_EVT_LOADKEY_SM_FINISHED:
  239. pEvt->SetHandled();
  240. break;
  241. case USER_EVT_ENCRYPT_SM_FINISHED:
  242. pEvt->SetHandled();
  243. break;
  244. case USER_EVT_GET_CHECKCODE:
  245. {
  246. pEvt->SetHandled();
  247. GetCheckCodeTask* task = new GetCheckCodeTask(this);
  248. GetCheckCodeEvent* gcce = dynamic_cast<GetCheckCodeEvent*>(pEvt);
  249. task->ctx = gcce->ctx;
  250. GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
  251. return 0;
  252. }
  253. default:
  254. break;
  255. }
  256. return 0;
  257. }
  258. void CPinPadFSM::s5_on_entry()
  259. {
  260. LOG_FUNCTION();
  261. m_eDevState = DEVICE_STATUS_FAULT;
  262. }
  263. void CPinPadFSM::s5_on_exit()
  264. {
  265. LOG_FUNCTION();
  266. }
  267. unsigned int CPinPadFSM::s5_on_event(FSMEvent* pEvt)
  268. {
  269. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s5 evt %d",pEvt->iEvt);
  270. switch (pEvt->iEvt)
  271. {
  272. default:
  273. break;
  274. }
  275. return 0;
  276. }
  277. void CPinPadFSM::s6_on_entry()
  278. {
  279. LOG_FUNCTION();
  280. m_eDevState = DEVICE_STATUS_NOT_READY;
  281. }
  282. void CPinPadFSM::s6_on_exit()
  283. {
  284. }
  285. unsigned int CPinPadFSM::s6_on_event(FSMEvent* pEvt)
  286. {
  287. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("s6 evt %d", pEvt->iEvt);
  288. switch (pEvt->iEvt)
  289. {
  290. default:
  291. break;
  292. }
  293. return 0;
  294. }
  295. int CPinPadFSM::Initial()
  296. {
  297. LOG_FUNCTION();
  298. #if defined(RVC_OS_WIN)
  299. DWORD dwCurrThId = GetCurrentThreadId();
  300. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Initial thread id:%d", dwCurrThId);
  301. #endif
  302. ErrorCodeEnum eErrDev;
  303. auto pEntity = GET_DEV_ENTITY_BASE_POINTER();
  304. GetEntityBase()->GetFunction()->GetSystemStaticInfo(m_sysStaticInfo);
  305. m_deviceNo = m_sysStaticInfo.strTerminalID;
  306. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("m_deviceNo:%s", m_deviceNo.GetData());
  307. m_devCheckData = "0000000000000000";
  308. CSimpleStringA csDepPath(""), csBackslash(SPLIT_SLASH_STR);
  309. eErrDev = pEntity->LoadVendorLibName();
  310. if (eErrDev != Error_Succeed)
  311. {
  312. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("LoadVendorLibName(%d) failed.", eErrDev);
  313. LogWarn(Severity_Middle, eErrDev, PinPad_UserErrorCode_Get_DevAdapter_Path_Failed, "Initial:LoadVendorLibName");
  314. m_bOpening = false;
  315. return Error_DevLoadFileFailed;
  316. }
  317. FulfillAdapterInfoFrom(pEntity->vendorLibInfo);
  318. pEntity->InitializeVendorLogSwitch();
  319. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("to load vendor dll[%s]", m_adapterInfo.adapterFilePath.IsNullOrEmpty() ? "null or empty" : m_adapterInfo.adapterFilePath.GetData());
  320. eErrDev = LoadUpAdapterLibrary();
  321. if (!IS_SUCCEED(eErrDev))
  322. {
  323. LogWarn(Severity_Middle, Error_NotInit, PinPad_UserErrorCode_Load_Dll_File_Failed, "密码键盘加载厂商适配器失败!请检查root.ini配置是否正确。");
  324. m_bOpening = false;
  325. return Error_DevLoadFileFailed;
  326. }
  327. else {
  328. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("load vendor dll suc.");
  329. }
  330. int initTries = 0;
  331. ErrorCodeEnum eErr = Error_Unexpect;
  332. do
  333. {
  334. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("port:%d,baudRate:%d", m_adapterInfo.GetPortInt(), m_adapterInfo.GetBaudrateInt());
  335. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  336. eErr = m_hDevHelper->DevOpen(m_adapterInfo.GetPortInt(), m_adapterInfo.GetBaudrateInt());
  337. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  338. if (eErr == Error_Succeed)
  339. {
  340. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::DevOpen").setCostTime(m_ullEndTime - m_ullBeginTime)();
  341. ToLogRootINIInfo();
  342. initTries = 0;
  343. ErrorCodeEnum errCode3, errCode4;
  344. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  345. //errCode1 = m_hDevHelper->SetParam(EPP_PT_SET_ENCRYPT_METHOD,EPP_ALGO_METHOD_3DES);
  346. //errCode2 = m_hDevHelper->SetParam(EPP_PT_SET_MAC_ALGORITH,EPP_MAC_ALGO_ASNIX99);
  347. errCode3 = m_hDevHelper->SetParam(EPP_PT_SET_PIN_ALGORITH, EPP_PIN_ALGO_SM4);
  348. errCode4 = m_hDevHelper->SetParam(EPP_PT_SET_ECB_CBC_MODE, EPP_ALGO_MODE_3DEC_CBC);
  349. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  350. if (errCode3 != Error_Succeed || errCode4 != Error_Succeed)
  351. {
  352. if (errCode3 != Error_Succeed)
  353. SetErrorAndLog(errCode3, MEC_DEVAPI_EPP_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime);
  354. if (errCode4 != Error_Succeed)
  355. SetErrorAndLog(errCode4, MEC_DEVAPI_EPP_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime);
  356. m_bOpening = false;
  357. return 1;
  358. }
  359. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::SetParam").setCostTime(m_ullEndTime - m_ullBeginTime)();
  360. break;
  361. }
  362. else
  363. {
  364. SetErrorAndLog(eErr, MEC_DEVAPI_EPP_DevOpen, "DevAdapter::DevOpen", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime);
  365. initTries++;
  366. Sleep(1200);
  367. continue;
  368. }
  369. } while (initTries < PINPAD_INIT_TRIES);
  370. m_bOpening = false;
  371. if (initTries != 0)
  372. {
  373. LogEvent(Severity_Middle, LOG_EVT_PINPAD_OPEN_FAIL, "Open pinpad failed.");
  374. DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("Open pinpad failed.");
  375. return 1;
  376. }
  377. m_bOpened = true;
  378. //oiltmp comment the following 20160406
  379. //update with the version 1.7.1
  380. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  381. m_encryptkey = m_hDevHelper->GetEncryptFunc();
  382. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  383. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::GetEncryptFunc").setCostTime(m_ullEndTime - m_ullBeginTime)("Error_Succeed");
  384. CSmartPointer<IConfigInfo> spConfig;
  385. eErrDev = GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spConfig);
  386. if (eErrDev != Error_Succeed)
  387. {
  388. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("read run cfg failed(sm).");
  389. m_bSMLoaded = false;
  390. LogWarn(Severity_Middle, eErrDev, PinPad_UserErrorCode_Open_RunCfgFile_Failed, "Initial:OpenConfig");
  391. }
  392. else
  393. {
  394. int tmpLoad = 0;
  395. eErrDev = spConfig->ReadConfigValueInt("Load", "SM", tmpLoad);
  396. if (eErrDev == Error_Succeed)
  397. m_bSMLoaded = tmpLoad;
  398. //oilyang@20201026 from kmc micro service
  399. spConfig->ReadConfigValue("Load", "SN_SM", m_keySNSM);
  400. spConfig->ReadConfigValue("Load", "ckckck", m_lastCheckCode);
  401. }
  402. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("encrypt key :%d,load key :%d", m_encryptkey, m_bSMLoaded);
  403. DevCategoryInfo devInfo;
  404. ZeroMemory(devInfo.szModel, MAX_DEV_MODEL_LEN);
  405. ZeroMemory(devInfo.szType, MAX_DEV_TYPE_LEN);
  406. ZeroMemory(devInfo.szVendor, MAX_DEV_VENDOR_LEN);
  407. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  408. eErrDev = m_hDevHelper->GetDevCategory(devInfo);
  409. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  410. if (eErrDev == Error_Succeed)
  411. {
  412. m_szModel = devInfo.szModel;
  413. m_szType = devInfo.szType;
  414. m_szVendor = devInfo.szVendor;
  415. m_adapterInfo.FulfillCategoryInfo(devInfo);
  416. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::GetDevCategory").setCostTime(m_ullEndTime - m_ullBeginTime)
  417. ("model,%d,%s;type,%d,%s;vendor,%d,%s", strlen(devInfo.szModel), m_szModel.GetData(), strlen(devInfo.szType), m_szType.GetData(), strlen(devInfo.szVendor), m_szVendor.GetData());
  418. }
  419. else
  420. SetErrorAndLog(eErrDev, MEC_DEVAPI_EPP_GetDevCategory, "DevAdapter::GetDevCategory", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime);
  421. CSimpleStringA xTmpStr = CSimpleStringA::Format("(hw support):%d,load key :%d,SMSN:%s", m_encryptkey, m_bSMLoaded, m_keySNSM.GetData());
  422. LogWarn(Severity_Low, Error_Unexpect, PinPad_UserErrorCode_DevConnect_CostTime, CSimpleStringA::Format("%d", (SP::Module::Comm::RVCGetTickCount() - m_ullConnectCost) / 1000));
  423. LogWarn(Severity_Low, Error_Unexpect, PinPad_UserErrorCode_PinPad_InfoAboutKey_Onboot, xTmpStr.GetData());
  424. LogEvent(Severity_Middle, LOG_EVT_PINPAD_OPEN_SUC, "Open pinpad suc.");
  425. //oiltmp@20240521 add for redundancy to check
  426. CSmartPointer<IConfigInfo> spConfigCen;
  427. int iTmp = 0;
  428. GetEntityBase()->GetFunction()->OpenConfig(Config_CenterSetting, spConfigCen);
  429. if (spConfigCen->ReadConfigValueInt(GetEntityBase()->GetEntityName(), "UseBackupSN", iTmp) == Error_Succeed)
  430. {
  431. if (iTmp == 1)
  432. m_bUseBackupSN = true;
  433. else if (iTmp > 1)//to except default value 0
  434. m_bUseBackupSN = false;
  435. }
  436. CSimpleStringA csRunInfo, csSNBakFile;
  437. if ((eErr = GetEntityBase()->GetFunction()->GetPath("RunInfo", csRunInfo)) == Error_Succeed)
  438. {
  439. csSNBakFile = csRunInfo + SPLIT_SLASH_STR + "runcfg" + SPLIT_SLASH_STR + "snbak.dat";
  440. ifstream infile(csSNBakFile, std::ofstream::binary);
  441. char* buffer = new char[16];
  442. ZeroMemory(buffer, 16);
  443. if (infile.is_open())
  444. infile.read(buffer, 16);
  445. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("bak.sn:%s", buffer);
  446. if (strlen(buffer) > 0 && m_keySNSM.Compare(buffer) != 0)
  447. {
  448. LogWarn(Severity_High, Error_Unexpect, PinPad_UserErrorCode_PinPad_SN_NOTMATCH, CSimpleStringA::Format("m_keySN:%s,snbak:%s", m_keySNSM.GetData(), buffer));
  449. if (m_bUseBackupSN)
  450. {
  451. m_keySNSM = buffer;
  452. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("because save failed, use backup sn:%s", m_keySNSM.GetData());
  453. }
  454. }
  455. delete[] buffer;
  456. infile.close();
  457. }
  458. return 0;
  459. }
  460. unsigned int __stdcall DoWork(void *pData)
  461. {
  462. while(1)
  463. {
  464. CPinPadFSM *pFsm = (CPinPadFSM*)pData;
  465. pFsm->m_hInputConVar.Wait();
  466. if (pFsm->GetEntityExit())
  467. break;
  468. FSMEvent *evt;
  469. int ret;
  470. if (!pFsm->GetDevInitFlag())
  471. {
  472. ret = pFsm->Initial();
  473. evt = new FSMEvent(USER_EVT_INITFINISHED);
  474. }
  475. else if (pFsm->IsInGetInputJS())
  476. {
  477. SpReqAnsContext<PinPadService_GetInputJS_Req, PinPadService_GetInputJS_Ans>::Pointer ctxJS;
  478. bool bRet = pFsm->GetJSCtx(ctxJS);
  479. if (!bRet)
  480. {
  481. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("get ctx(JS) failed.doing nothing");
  482. continue;
  483. }
  484. ret = pFsm->GetInputJS(ctxJS);
  485. evt = new FSMEvent(USER_EVT_GETINPUT_JS_FINISHED);
  486. }
  487. else
  488. {
  489. SpReqAnsContext<PinPadService_GetInputSM_Req, PinPadService_GetInputSM_Ans>::Pointer ctxSM;
  490. bool bRet = pFsm->GetCtx(ctxSM);
  491. if (!bRet)
  492. {
  493. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("get ctx failed.doing nothing");
  494. continue;
  495. }
  496. ret = pFsm->GetInput(ctxSM);
  497. evt = new FSMEvent(USER_EVT_GETINPUT_SM_FINISHED);
  498. }
  499. if (ret == 0)
  500. evt->param1 = 0;
  501. else
  502. evt->param1 = 1;
  503. pFsm->PostEventFIFO(evt);
  504. }
  505. #if defined(RVC_OS_WIN)
  506. _endthreadex(0);
  507. #else
  508. pthread_exit(0);
  509. #endif //RVC_OS_WIN
  510. return 0;
  511. }
  512. void CPinPadFSM::push_char(char *buf, int *len, int c)
  513. {
  514. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("len:%d",*len);
  515. buf[*len] = c;
  516. *len = *len + 1;
  517. buf[*len] = 0;
  518. InputContent evt;
  519. evt.data = buf;
  520. SpSendBroadcast(GetEntityBase()->GetFunction(), SP_MSG_OF(InputContent), SP_MSG_SIG_OF(InputContent), evt);
  521. }
  522. void CPinPadFSM::pop_char(char *buf, int *len, bool bClear)
  523. {
  524. if (*len > 0) {
  525. if (bClear){
  526. memset(buf,0,*len);
  527. *len = 0;
  528. }else {
  529. *len -= 1;
  530. buf[*len] = 0;
  531. }
  532. InputContent evt;
  533. evt.data = buf;
  534. SpSendBroadcast(GetEntityBase()->GetFunction(), SP_MSG_OF(InputContent), SP_MSG_SIG_OF(InputContent), evt);
  535. }
  536. }
  537. void CPinPadFSM::clear_char(char *buf, int *len)
  538. {
  539. if (*len > 0) {
  540. *len = 0;
  541. buf[*len] = 0;
  542. InputContent evt;
  543. evt.data = buf;
  544. SpSendBroadcast(GetEntityBase()->GetFunction(), SP_MSG_OF(InputContent), SP_MSG_SIG_OF(InputContent), evt);
  545. }
  546. }
  547. bool CPinPadFSM::Get12Account(char *szAcc)
  548. {
  549. memset(m_szAccount,0,sizeof(m_szAccount));
  550. const int accLen = strlen(szAcc);
  551. if (accLen == 0) {
  552. return false;
  553. }
  554. if (accLen > 12)
  555. memcpy(m_szAccount + 4, szAcc + (accLen - 12 -1), 12);
  556. else if (accLen == 12)
  557. {
  558. if (strncmp(szAcc, "0755", 4) == 0)
  559. memcpy(m_szAccount + 4, szAcc, 12);
  560. else
  561. {
  562. m_szAccount[4] = '5';
  563. memcpy(m_szAccount + 5, szAcc + 1, 11);
  564. }
  565. }
  566. else if (accLen == 9)
  567. {
  568. memcpy(m_szAccount + 4, szAcc, 3);
  569. memcpy(m_szAccount + 7, szAcc, 9);
  570. }
  571. else
  572. memcpy(m_szAccount + 4, szAcc, accLen);
  573. return true;
  574. }
  575. ErrorCodeEnum CPinPadFSM::GetEncryptText(SpReqAnsContext<PinPadService_GetInputSM_Req, PinPadService_GetInputSM_Ans>::Pointer ctxSM)
  576. {
  577. LOG_FUNCTION();
  578. ErrorCodeEnum errCode;
  579. CSmartPointer<IEntityFunction> spEntityFunction = GetEntityBase()->GetFunction();
  580. int len, timeout;
  581. bool confirm, bSMFlag = false;
  582. len = ctxSM->Req.length;
  583. timeout = ctxSM->Req.timeout;
  584. confirm = ctxSM->Req.confirm;
  585. if (ctxSM->Req.smflag == 1)
  586. {
  587. bSMFlag = true;
  588. }
  589. if (!bSMFlag)
  590. {
  591. LogWarn(Severity_Low, Error_Unexpect, PinPad_UserErrorCode_PinPad_Not_SM, "Encryption is not SM");
  592. ctxSM->Answer(Error_Unexpect, PinPad_UserErrorCode_UnknownSMFlag);
  593. return Error_Unexpect;
  594. }
  595. AccountInfo accInfo;
  596. memset(accInfo.account, 0, MAX_ACCOUNT_LEN);
  597. CSimpleStringA errMsg(true);
  598. if (Get12Account(const_cast<char*>(ctxSM->Req.account.GetData())))
  599. memcpy(accInfo.account, m_szAccount + 4, 12);
  600. else
  601. {
  602. errMsg = CSimpleStringA::Format("Get12Account err(%s).", (const char*)ctxSM->Req.account);
  603. if (IsInBusiness())
  604. {
  605. DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_USER).setLogCode(PinPadService_LogCode_GetInputSM).setResultCode("RTA2607")(errMsg.GetData());
  606. LogError(Severity_High, Error_Unexpect, PinPad_UserErrorCode_PinPad_GetEncryptText_Get12Account_Error, errMsg.GetData());
  607. }
  608. else
  609. LogWarn(Severity_High, Error_Unexpect, PinPad_UserErrorCode_PinPad_GetEncryptText_Get12Account_Error, errMsg.GetData());
  610. ctxSM->Answer(Error_DevCommFailed, PinPad_UserErrorCode_PinPad_GetEncryptText_Get12Account_Error);
  611. return Error_DevCommFailed;
  612. }
  613. //memcpy(accInfo.account,"588571006555",12);
  614. accInfo.dwAccLen = 12;
  615. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("acc(%s)", accInfo.account);
  616. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  617. errCode = m_hDevHelper->SetAccNo(accInfo);
  618. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  619. if (errCode != Error_Succeed)
  620. {
  621. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("[sm]set accout(%s)(%s) failed(%d).", (const char*)ctxSM->Req.account, accInfo.account, errCode);
  622. SetErrorAndLog(errCode, MEC_DEVAPI_EPP_SetAccNo, "DevAdapter::SetAccNo", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetInputSM);
  623. ctxSM->Answer(Error_DevCommFailed, GetAlarmDEC());
  624. return Error_DevCommFailed;
  625. }
  626. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::SetAccNo").setCostTime(m_ullEndTime - m_ullBeginTime)();
  627. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  628. errCode = m_hDevHelper->ActiveWorkingKey(1, 0);
  629. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  630. if (errCode != Error_Succeed)
  631. {
  632. SetErrorAndLog(errCode, MEC_DEVAPI_EPP_ActiveWorkingKey, "DevAdapter::ActiveWorkingKey", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetInputSM);
  633. ctxSM->Answer(Error_DevCommFailed, GetAlarmDEC());
  634. return Error_DevCommFailed;
  635. }
  636. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::ActiveWorkingKey").setCostTime(m_ullEndTime - m_ullBeginTime)();
  637. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  638. errCode = m_hDevHelper->SetParam(EPP_PT_SET_PIN_ALGORITH, EPP_PIN_ALGO_SM4);
  639. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  640. if (errCode != Error_Succeed)
  641. {
  642. SetErrorAndLog(errCode, MEC_DEVAPI_EPP_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetInputSM);
  643. ctxSM->Answer(Error_DevCommFailed, GetAlarmDEC());
  644. return Error_DevCommFailed;
  645. }
  646. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::SetParam").setCostTime(m_ullEndTime - m_ullBeginTime)();
  647. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  648. errCode = m_hDevHelper->StartPinInput(len);
  649. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  650. if (errCode != Error_Succeed)
  651. {
  652. SetErrorAndLog(errCode, MEC_DEVAPI_EPP_StartPinInput, "DevAdapter::StartPinInput", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetInputSM);
  653. DWORD dwCode = GetAlarmDEC();
  654. ctxSM->Answer(Error_DevCommFailed, dwCode);
  655. CSimpleStringA tmpRTA(true), tmpDesc(true);
  656. if (GetEntityBase()->GetFunction()->GetVTMErrMsg(dwCode, tmpDesc, tmpRTA) == Error_Succeed)
  657. DbgToBeidou(ctxSM->link, "GetEncryptTextJS").setReturnCode(tmpRTA)();
  658. return Error_DevCommFailed;
  659. }
  660. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::StartPinInput").setCostTime(m_ullEndTime - m_ullBeginTime)();
  661. DbgToBeidou(ctxSM->link, "GetEncryptText")();
  662. char* buf = new char[len + 1];
  663. memset(buf, 0, len + 1);
  664. int readed = 0;
  665. DWORD elapsed = 0;
  666. DWORD dwStart = GetTickCount();
  667. DWORD dwEnd = GetTickCount();
  668. bool bCancelInput = false;
  669. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("req(pin)len:[%d],timeout:[%d],confirm:[%d],bExit(%d)", len, timeout, confirm, m_bExit);
  670. while (elapsed < MAX_PINPAD_INPUT_TIMEOUT) {
  671. if (m_bExit)
  672. break;
  673. if (!confirm && readed >= len)
  674. break;
  675. if (m_bWaitingMore)
  676. {
  677. dwStart = GetTickCount();
  678. elapsed = 0;
  679. m_bWaitingMore = false;
  680. continue;
  681. }
  682. if (m_bFrontCancel)
  683. {
  684. bCancelInput = true;
  685. goto Err;
  686. }
  687. BYTE btCh;
  688. Sleep(100);
  689. errCode = m_hDevHelper->KeyRead(btCh);//循环调用,无需计算耗时
  690. if (errCode == Error_Succeed) {
  691. LogEvent(Severity_Middle, LOG_EVT_PINPAD_OP, "PinPad op.", ctxSM->link);
  692. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("PinPad op: %d", readed);
  693. if (btCh == 0x0d) {
  694. if (confirm)
  695. {
  696. ctxSM->Ans.enter = true;
  697. if (buf != NULL)
  698. delete[]buf;
  699. ctxSM->Answer(Error_Succeed);
  700. return Error_Succeed;
  701. }
  702. else
  703. {
  704. dwEnd = GetTickCount();
  705. elapsed = dwEnd - dwStart;
  706. continue;
  707. }
  708. }
  709. else if (btCh == 0x08) { // back
  710. if (confirm)
  711. {
  712. dwEnd = GetTickCount();
  713. elapsed = dwEnd - dwStart;
  714. continue;
  715. }
  716. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("clear input");
  717. pop_char(buf, &readed,true);
  718. } else if (btCh == 0x1b) { // quit
  719. if (confirm)
  720. {
  721. ctxSM->Ans.enter = true;
  722. if (buf != NULL)
  723. delete[]buf;
  724. ctxSM->Answer(Error_Succeed);
  725. return Error_Succeed;
  726. }
  727. else
  728. {
  729. bCancelInput = true;
  730. goto Err;
  731. }
  732. }
  733. else if (btCh == 0x3f) {
  734. if (confirm)
  735. {
  736. dwEnd = GetTickCount();
  737. elapsed = dwEnd - dwStart;
  738. continue;
  739. }
  740. push_char(buf, &readed, '*');
  741. }else{
  742. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("else[%d]",btCh);
  743. }
  744. }
  745. else {
  746. }
  747. dwEnd = GetTickCount();
  748. elapsed = dwEnd - dwStart;
  749. }
  750. buf[readed] = 0;
  751. Err:
  752. if (m_bExit)
  753. {
  754. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("exit");
  755. ctxSM->Answer(Error_Unexpect, PinPad_UserErrorCode_Unexpected_Exit);
  756. return Error_Unexpect;
  757. }
  758. m_bExit = false;
  759. if (buf != NULL)
  760. delete[]buf;
  761. if (bCancelInput)
  762. {
  763. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode("QLR040220602")("input cancel(pin)");
  764. ctxSM->Answer(Error_Cancel);
  765. return Error_Cancel;
  766. }
  767. if (readed < len) {
  768. if (elapsed >= MAX_PINPAD_INPUT_TIMEOUT) {
  769. ctxSM->Answer(Error_TimeOut);
  770. return Error_TimeOut;
  771. }
  772. }
  773. PinBlock pinBlk;
  774. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("to getpinblk");
  775. Sleep(500);//nantian
  776. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  777. errCode = m_hDevHelper->GetPinBlock(pinBlk);
  778. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  779. LogWarn(Severity_Low, Error_Succeed, PinPad_UserErrorCode_PinPad_GetPinBlock_Call
  780. , CSimpleStringA::Format("{\"cost\":%d}", m_ullEndTime - m_ullBeginTime));
  781. if (errCode == Error_Succeed)
  782. {
  783. char* tmpPinData = new char[MAX_PIN_BLOCK_SIZE];
  784. if (tmpPinData == NULL)
  785. return Error_Resource;
  786. memset(tmpPinData, 0, MAX_PIN_BLOCK_SIZE);
  787. memcpy(tmpPinData, pinBlk.data, pinBlk.dwSize);
  788. ctxSM->Ans.data = tmpPinData;
  789. //Dbg("pinblk(%s)",tmpPinData);
  790. if (tmpPinData != NULL)
  791. {
  792. delete[]tmpPinData;
  793. tmpPinData = NULL;
  794. }
  795. EnDecryptInfo srcInfo, dstInfo;
  796. memset(srcInfo.data, 0, MAX_EN_DECRYPT_DATA_SIZE);
  797. memcpy(srcInfo.data, m_devCheckData, m_devCheckData.GetLength());
  798. srcInfo.dwSize = m_devCheckData.GetLength();
  799. memset(dstInfo.data, 0, MAX_EN_DECRYPT_DATA_SIZE);
  800. //set param
  801. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  802. errCode = m_hDevHelper->SetParam(EPP_PT_SET_ENCRYPT_METHOD, EPP_ALGO_METHOD_SM4);
  803. if (errCode == Error_Succeed)
  804. errCode = m_hDevHelper->SetParam(EPP_PT_SET_ECB_CBC_MODE, EPP_ALGO_MODE_CBC);
  805. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  806. if (errCode != Error_Succeed)
  807. {
  808. SetErrorAndLog(errCode, MEC_DEVAPI_EPP_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetInputSM);
  809. ctxSM->Answer(Error_Param, GetAlarmDEC());
  810. return Error_Param;
  811. }
  812. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::SetParam").setCostTime(m_ullEndTime - m_ullBeginTime)();
  813. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  814. errCode = m_hDevHelper->EncryptData(srcInfo, dstInfo);
  815. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  816. if (errCode != Error_Succeed)
  817. {
  818. SetErrorAndLog(errCode, MEC_DEVAPI_EPP_EncryptData, "DevAdapter::EncryptData", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetInputSM);
  819. ctxSM->Answer(Error_DevCommFailed, GetAlarmDEC());
  820. return Error_DevCommFailed;
  821. }
  822. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::EncryptData").setCostTime(m_ullEndTime - m_ullBeginTime)();
  823. char* tmpCheckCode = new char[MAX_PIN_BLOCK_SIZE];
  824. if (tmpCheckCode == NULL)
  825. return Error_Resource;
  826. memset(tmpCheckCode, 0, MAX_PIN_BLOCK_SIZE);
  827. //HexBuf2StrBuf(dstInfo.data,&tmpCheckCode,dstInfo.dwSize);
  828. memcpy(tmpCheckCode, dstInfo.data, dstInfo.dwSize);
  829. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ckckck[%s], m_keySNSM:%s", tmpCheckCode, m_keySNSM.GetData());
  830. if (strnicmp(tmpCheckCode, "9F1F7BFF6F5511384D9430531E538FD3", strlen("9F1F7BFF6F5511384D9430531E538FD3")) == 0)
  831. SetErrorAndLog(Error_Unexpect, PinPad_UserErrorCode_KEY_LOST_SM, "", __FUNCTION__);
  832. ctxSM->Ans.checkcode = tmpCheckCode;
  833. ctxSM->Ans.deviceno = m_deviceNo;
  834. ctxSM->Ans.keyseq = m_keySNSM;
  835. CSimpleStringA tmpLastCkCode = m_lastCheckCode;
  836. if (m_lastCheckCode.IsNullOrEmpty() || strnicmp(tmpCheckCode, m_lastCheckCode, m_lastCheckCode.GetLength()) != 0)
  837. {
  838. ErrorCodeEnum eErr;
  839. CSmartPointer<IConfigInfo> spConfigRun;
  840. eErr = GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spConfigRun);
  841. if (eErr == Error_Succeed)
  842. {
  843. spConfigRun->WriteConfigValue("Load", "ckckck", tmpCheckCode);
  844. m_lastCheckCode = tmpCheckCode;
  845. }
  846. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("write ckckck:%s", tmpCheckCode);
  847. }
  848. if (!tmpLastCkCode.IsNullOrEmpty() && strnicmp(tmpCheckCode, tmpLastCkCode, tmpLastCkCode.GetLength()) != 0)
  849. {
  850. CSimpleStringA xCkChangeMsg = CSimpleStringA::Format("last ck:%s,current ck:%s,m_keySNSM:%s", tmpLastCkCode.GetData()
  851. , tmpCheckCode, m_keySNSM.GetData());
  852. LogWarn(Severity_Low, Error_Unexpect, PinPad_UserErrorCode_PinPad_CheckCode_Changed, xCkChangeMsg.GetData());
  853. }
  854. }
  855. else
  856. {
  857. SetErrorAndLog(errCode, MEC_DEVAPI_EPP_GetPinBlock, "DevAdapter::GetPinBlock", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetInputSM);
  858. ctxSM->Answer(Error_DevCommFailed, GetAlarmDEC());
  859. return Error_DevCommFailed;
  860. }
  861. DbgWithLink(LOG_LEVEL_INFO, ctxSM->link.checkEmpty() ? LOG_TYPE_SYSTEM : LOG_TYPE_USER).setLogCode(PinPadService_LogCode_GetInputSM)
  862. .setAPI("DevAdapter::GetPinBlock").setCostTime(m_ullEndTime - m_ullBeginTime)("获取密文成功");
  863. //oilyang@20240410 move to out space,after stopinput & turn off the light
  864. //Sleep(100);
  865. //ctxSM->Answer(Error_Succeed);
  866. return Error_Succeed;
  867. }
  868. int CPinPadFSM::GetInput(SpReqAnsContext<PinPadService_GetInputSM_Req, PinPadService_GetInputSM_Ans>::Pointer ctxSM)
  869. {
  870. DWORD dwCurrThId = GetCurrentThreadId();
  871. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("GetInput thread id:%d",dwCurrThId);
  872. m_bWaitingMore = false;
  873. m_bFrontCancel = false;
  874. m_bExit = false;
  875. LogEvent(Severity_Middle, LOG_EVT_PINPAD_GREEN_ON, "PinPad light on.");
  876. if (!m_hDevHelper)
  877. {
  878. SetErrorAndLog(Error_Unexpect, PinPad_UserErrorCode_PinPad_Instance_Is_Null, "", __FUNCTION__, false, 0, PinPadService_LogCode_GetInputSM);
  879. m_inputSMCtx->Answer(Error_Unexpect, GetAlarmDEC());
  880. LogEvent(Severity_Middle, LOG_EVT_PINPAD_GREEN_OFF, "PinPad light off.");
  881. m_bPinInput = false;
  882. return 1;
  883. }
  884. if (!m_inputSMCtx->Req.encrypt)
  885. {
  886. SetErrorAndLog(Error_Unexpect, PinPad_UserErrorCode_NoPlainInput, "", __FUNCTION__, false, 0, PinPadService_LogCode_GetInputSM);
  887. m_inputSMCtx->Answer(Error_Unexpect, GetAlarmDEC());
  888. return 1;
  889. }
  890. ULLINT ullGetInputBegin = SP::Module::Comm::RVCGetTickCount();
  891. ErrorCodeEnum eErrCode = GetEncryptText(m_inputSMCtx);
  892. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  893. ErrorCodeEnum errClosePinPad = m_hDevHelper->StopInput();
  894. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  895. if (errClosePinPad != Error_Succeed)
  896. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI("DevAdapter::StopInput").setResultCode("RTA2614").setCostTime(m_ullEndTime - m_ullBeginTime)("close pinpad(%s).", SpStrError(errClosePinPad));
  897. else
  898. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::StopInput").setCostTime(m_ullEndTime - m_ullBeginTime)("StopInput cost(%d)ms", m_ullEndTime - m_ullBeginTime);
  899. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)
  900. ("req acc.len:%d,confirm:%d,len:%d. ans:ck.len:%d", m_inputSMCtx->Req.account.GetLength(), m_inputSMCtx->Req.confirm
  901. , m_inputSMCtx->Req.length, m_inputSMCtx->Ans.checkcode.IsNullOrEmpty() ? 0 : m_inputSMCtx->Ans.checkcode.GetLength());
  902. DbgToBeidou(m_inputSMCtx->link, "GetInput")();
  903. m_bPinInput = false;
  904. LogEvent(Severity_Middle, LOG_EVT_PINPAD_GREEN_OFF, "PinPad light off.");
  905. if (eErrCode == Error_Succeed && !m_inputSMCtx->Req.confirm)
  906. {
  907. ULLINT ullGetInputEnd = SP::Module::Comm::RVCGetTickCount();
  908. LogWarn(Severity_Low, Error_Unexpect, PinPad_UserErrorCode_GetInput_TimeCost, CSimpleStringA::Format("%d", (ullGetInputEnd - ullGetInputBegin) / 1000));
  909. m_inputSMCtx->Answer(Error_Succeed);
  910. }
  911. return 0;
  912. }
  913. int CPinPadFSM::LoadKeySM(SpReqAnsContext<PinPadService_LoadKeysSM_Req, PinPadService_LoadKeysSM_Ans>::Pointer ctx)
  914. {
  915. ErrorCodeEnum eErr;
  916. CSmartPointer<IEntityFunction> spEntityFunction = GetEntityBase()->GetFunction();
  917. CSmartPointer<IConfigInfo> spConfig;
  918. eErr = spEntityFunction->OpenConfig(Config_Run, spConfig);
  919. if (eErr != Error_Succeed)
  920. {
  921. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("LoadKeySM::OpenConfig failed,eErr:%d", eErr);
  922. spConfig = NULL;
  923. ctx->Answer(eErr, PinPad_UserErrorCode_Open_RunCfgFile_Failed);
  924. return 0;
  925. }
  926. if (!(ctx->Req.smflag == 1))
  927. {
  928. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("密钥标识不支持,ctx->Req.smflag:%d", ctx->Req.smflag);
  929. ctx->Answer(Error_Unexpect, PinPad_UserErrorCode_UnknownSMFlag);
  930. return 0;
  931. }
  932. //initialization need load master key
  933. if (ctx->Req.initializeflag)
  934. {
  935. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("mkey len:%d,ctx->Req.smflag:%d", strlen(ctx->Req.masterkey), ctx->Req.smflag);
  936. MasterKeyParam mkParam;
  937. mkParam.dwSN = 1;
  938. mkParam.smFlag = ctx->Req.smflag;
  939. memset(mkParam.key, 0, MAX_MASTER_KEY_SIZE);
  940. memcpy(mkParam.key, ctx->Req.masterkey, strlen(ctx->Req.masterkey));
  941. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  942. eErr = m_hDevHelper->LoadMasterKey(mkParam);
  943. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  944. if (eErr != Error_Succeed)
  945. {
  946. SetErrorAndLog(eErr, MEC_DEVAPI_EPP_LoadMasterKey, "DevAdapter::LoadMasterKey", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime);
  947. ctx->Ans.result = 0;
  948. ctx->Answer(Error_Unexpect, GetAlarmDEC());
  949. m_bLoadKey = false;
  950. return 0;
  951. }
  952. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::LoadMasterKey").setCostTime(m_ullEndTime - m_ullBeginTime)();
  953. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(PinPadService_LogCode_LoadKeysSM)("Load master key suc.");
  954. //after load Master key,clear the load key status
  955. spConfig->WriteConfigValueInt("Load", "SM", 0);
  956. }
  957. WorkKeyParam wkParam1, wkParam2;
  958. memset(wkParam1.key, 0, MAX_WORKING_KEY_SIZE);
  959. memset(wkParam2.key, 0, MAX_WORKING_KEY_SIZE);
  960. wkParam1.dwMasterSN = wkParam2.dwMasterSN = 1;
  961. wkParam1.dwWorkingSN = 0;
  962. wkParam2.dwWorkingSN = 1;
  963. wkParam1.smFlag = ctx->Req.smflag;
  964. wkParam2.smFlag = ctx->Req.smflag;
  965. memcpy(wkParam1.key, ctx->Req.workingkey1, strlen(ctx->Req.workingkey1));
  966. memcpy(wkParam2.key, ctx->Req.workingkey2, strlen(ctx->Req.workingkey2));
  967. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  968. eErr = m_hDevHelper->LoadWorkingKey(wkParam1);
  969. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  970. if (eErr != Error_Succeed)
  971. {
  972. SetErrorAndLog(eErr, MEC_DEVAPI_EPP_LoadWorkingKey, "DevAdapter::LoadWorkingKey", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime);
  973. ctx->Ans.result = 1;
  974. ctx->Answer(Error_Unexpect, GetAlarmDEC());
  975. m_bLoadKey = false;
  976. return 0;
  977. }
  978. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::LoadWorkingKey").setCostTime(m_ullEndTime - m_ullBeginTime)("Load working key1 suc.");
  979. //oilyang@20220308 to calc checkcode if called Initializer
  980. if (ctx->Req.initializeflag)
  981. {
  982. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("the new check code:%s", ctx->Req.reserved4.GetData());
  983. LogWarn(Severity_Low, Error_Unexpect, PinPad_UserErrorCode_PinPad_CkCode_While_Load_SM, ctx->Req.reserved4);
  984. }
  985. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  986. eErr = m_hDevHelper->LoadWorkingKey(wkParam2);
  987. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  988. if (eErr != Error_Succeed)
  989. {
  990. SetErrorAndLog(eErr, MEC_DEVAPI_EPP_LoadWorkingKey, "DevAdapter::LoadWorkingKey", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime);
  991. ctx->Ans.result = 2;
  992. ctx->Answer(Error_Unexpect, GetAlarmDEC());
  993. m_bLoadKey = false;
  994. return 0;
  995. }
  996. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::LoadWorkingKey").setCostTime(m_ullEndTime - m_ullBeginTime)("Load working key2 suc.");
  997. if (spConfig != NULL)
  998. {
  999. eErr = spConfig->WriteConfigValueInt("Load", "SM", 1);
  1000. if (eErr != Error_Succeed)
  1001. {
  1002. DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setResultCode("RTA2613")("写密钥加载标识失败:%s", SpStrError(eErr));
  1003. LogWarn(Severity_Middle, Error_Unexpect, PinPad_UserErrorCode_Write_RunCfgFile_Failed, CSimpleStringA::Format("写密钥加载标识失败:%s", SpStrError(eErr)));
  1004. }
  1005. if (!ctx->Req.reserved3.IsNullOrEmpty())
  1006. {
  1007. if ((eErr = spConfig->WriteConfigValue("Load", "SN_SM", ctx->Req.reserved3)) != Error_Succeed)
  1008. {
  1009. DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setResultCode("RTA2613")("写密钥序号失败:%s", SpStrError(eErr));
  1010. LogWarn(Severity_Middle, Error_Unexpect, PinPad_UserErrorCode_Write_RunCfgFile_Failed, CSimpleStringA::Format("写密钥序号失败:%s", SpStrError(eErr)));
  1011. }
  1012. m_keySNSM = ctx->Req.reserved3;
  1013. LogWarn(Severity_Low, Error_Unexpect, PinPad_UserErrorCode_PinPad_LoadKey_SMSN
  1014. , CSimpleStringA::Format("{\"subject\":\"key_sn\",\"value\":\"%s\"}", m_keySNSM.GetData()));
  1015. //oiltmp@20240521 add for redundancy to check
  1016. CSimpleStringA csRunInfo,csSNBakFile;
  1017. if ((eErr = GetEntityBase()->GetFunction()->GetPath("RunInfo", csRunInfo)) == Error_Succeed)
  1018. {
  1019. csSNBakFile = csRunInfo + SPLIT_SLASH_STR + "runcfg" + SPLIT_SLASH_STR + "snbak.dat";
  1020. ofstream outfile(csSNBakFile, std::ofstream::binary|ios::trunc);
  1021. int size = m_keySNSM.GetLength();
  1022. char* buffer = new char[size + 1];
  1023. ZeroMemory(buffer, size + 1);
  1024. memcpy(buffer, m_keySNSM.GetData(), size);
  1025. outfile.write(buffer, size);
  1026. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("write sn bak:%s", buffer);
  1027. delete[] buffer;
  1028. outfile.close();
  1029. }
  1030. }
  1031. else
  1032. {
  1033. spConfig->WriteConfigValue("Load", "SN_SM", "");
  1034. m_keySNSM = "";
  1035. LogWarn(Severity_Low, Error_Unexpect, PinPad_UserErrorCode_PinPad_LoadKey_Clear_SMSN, "clear sm key sn");
  1036. }
  1037. }
  1038. m_bLoadKey = false;
  1039. m_bSMLoaded = true;
  1040. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(PinPadService_LogCode_LoadKeysSM)("加载密钥成功");
  1041. ctx->Answer(Error_Succeed);
  1042. return 0;
  1043. }
  1044. int CPinPadFSM::EncryptSM(SpReqAnsContext<PinPadService_EncryptDataSM_Req, PinPadService_EncryptDataSM_Ans>::Pointer ctx)
  1045. {
  1046. if (!(ctx->Req.smflag == 1))
  1047. {
  1048. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("密钥标识不支持,ctx->Req.smflag:%d", ctx->Req.smflag);
  1049. ctx->Answer(Error_Unexpect, PinPad_UserErrorCode_UnknownSMFlag);
  1050. return 0;
  1051. }
  1052. //set param
  1053. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  1054. if (m_hDevHelper->SetParam(EPP_PT_SET_ENCRYPT_METHOD, EPP_ALGO_METHOD_SM4) != Error_Succeed
  1055. || m_hDevHelper->SetParam(EPP_PT_SET_ECB_CBC_MODE, EPP_ALGO_MODE_CBC) != Error_Succeed)
  1056. {
  1057. SetErrorAndLog(Error_Unexpect, MEC_DEVAPI_EPP_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime);
  1058. ctx->Answer(Error_Unexpect, GetAlarmDEC());
  1059. m_bEncrypt = false;
  1060. return 0;
  1061. }
  1062. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  1063. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  1064. ErrorCodeEnum eErr = m_hDevHelper->ActiveWorkingKey(1, 1);
  1065. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  1066. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(PinPadService_LogCode_EncryptDataSM).setCostTime(m_ullEndTime - m_ullBeginTime)("%s", SpStrError(eErr));
  1067. if (eErr != Error_Succeed)
  1068. {
  1069. SetErrorAndLog(eErr, MEC_DEVAPI_EPP_ActiveWorkingKey, "DevAdapter::ActiveWorkingKey", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime);
  1070. DWORD dwCode = GetAlarmDEC();
  1071. ctx->Answer(Error_Unexpect, dwCode);
  1072. CSimpleStringA tmpRTA(true), tmpDesc(true);
  1073. if (GetEntityBase()->GetFunction()->GetVTMErrMsg(dwCode, tmpDesc, tmpRTA) == Error_Succeed)
  1074. DbgToBeidou(ctx->link, "ActiveWorkingKey").setReturnCode(tmpRTA)();
  1075. m_bEncrypt = false;
  1076. return 0;
  1077. }
  1078. DbgToBeidou(ctx->link, "ActiveWorkingKey")();
  1079. EnDecryptInfo srcData, dstData;
  1080. ZeroMemory(srcData.data, MAX_EN_DECRYPT_DATA_SIZE);
  1081. ZeroMemory(dstData.data, MAX_EN_DECRYPT_DATA_SIZE);
  1082. srcData.dwSize = strlen(ctx->Req.data);
  1083. memcpy(srcData.data, ctx->Req.data, srcData.dwSize);
  1084. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  1085. eErr = m_hDevHelper->EncryptData(srcData, dstData);
  1086. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  1087. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::EncryptData").setCostTime(m_ullEndTime - m_ullBeginTime)("%s", SpStrError(eErr));
  1088. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(PinPadService_LogCode_EncryptDataSM)("srcData.dwSize:%d,dstData.dwSize", srcData.dwSize, dstData.dwSize);
  1089. DbgToBeidou(ctx->link, "EncryptData")();
  1090. if (eErr != Error_Succeed)
  1091. {
  1092. SetErrorAndLog(eErr, MEC_DEVAPI_EPP_EncryptData, "DevAdapter::EncryptData", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime);
  1093. ctx->Answer(Error_Unexpect, GetAlarmDEC());
  1094. m_bEncrypt = false;
  1095. return 0;
  1096. }
  1097. ctx->Ans.ciphertext = (char*)dstData.data;
  1098. m_bEncrypt = false;
  1099. ctx->Answer(Error_Succeed);
  1100. return 0;
  1101. }
  1102. ErrorCodeEnum CPinPadFSM::GetCheckCode(SpReqAnsContext<PinPadService_GetCheckCode_Req, PinPadService_GetCheckCode_Ans>::Pointer ctx)
  1103. {
  1104. ErrorCodeEnum eErr = Error_Unexpect;
  1105. bool bGetOK = true;
  1106. ctx->Ans.checkcode.Init(ctx->Req.mSN.GetCount());
  1107. ctx->Ans.index.Init(ctx->Req.mSN.GetCount());
  1108. for (int i = 0; i < ctx->Req.mSN.GetCount(); i++)
  1109. {
  1110. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("mSN:%d,wSN:%d,origData[%s]", ctx->Req.mSN[i], ctx->Req.wSN[i], m_devCheckData.GetData());
  1111. //set param
  1112. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  1113. if (ctx->Req.mSN[i] == 1)
  1114. eErr = m_hDevHelper->SetParam(EPP_PT_SET_ENCRYPT_METHOD, EPP_ALGO_METHOD_SM4);
  1115. else
  1116. {
  1117. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(PinPadService_LogCode_GetCheckCode).setResultCode("RTA260B")("mSN:%d", ctx->Req.mSN[i]);
  1118. ctx->Ans.checkcode[i] = "";
  1119. ctx->Ans.index[i] = "";
  1120. continue;
  1121. }
  1122. if (eErr == Error_Succeed)
  1123. eErr = m_hDevHelper->SetParam(EPP_PT_SET_ECB_CBC_MODE, EPP_ALGO_MODE_CBC);
  1124. else
  1125. {
  1126. SetErrorAndLog(eErr, MEC_DEVAPI_EPP_SetParam, "DevAdapter::SetParam", __FUNCTION__, false, m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetCheckCode);
  1127. return Error_DevCommFailed;
  1128. }
  1129. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  1130. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  1131. eErr = m_hDevHelper->ActiveWorkingKey(ctx->Req.mSN[i], ctx->Req.wSN[i]);
  1132. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  1133. if (eErr != Error_Succeed)
  1134. {
  1135. SetErrorAndLog(eErr, MEC_DEVAPI_EPP_ActiveWorkingKey, "DevAdapter::ActiveWorkingKey", __FUNCTION__, false, m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetCheckCode);
  1136. ctx->Ans.checkcode[i] = "";
  1137. return Error_DevCommFailed;
  1138. }
  1139. else
  1140. {
  1141. EnDecryptInfo srcInfo, dstInfo;
  1142. memset(srcInfo.data, 0, MAX_EN_DECRYPT_DATA_SIZE);
  1143. memcpy(srcInfo.data, m_devCheckData, m_devCheckData.GetLength());
  1144. srcInfo.dwSize = m_devCheckData.GetLength();
  1145. memset(dstInfo.data, 0, MAX_EN_DECRYPT_DATA_SIZE);
  1146. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  1147. eErr = m_hDevHelper->EncryptData(srcInfo, dstInfo);
  1148. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  1149. if (eErr != Error_Succeed)
  1150. {
  1151. SetErrorAndLog(eErr, MEC_DEVAPI_EPP_EncryptData, "DevAdapter::EncryptData", __FUNCTION__, false, m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetCheckCode);
  1152. return Error_DevCommFailed;
  1153. }
  1154. ctx->Ans.checkcode[i] = (const char*)dstInfo.data;
  1155. if (ctx->Req.wSN[i] == 0)
  1156. ctx->Ans.index[i] = m_keySNSM;
  1157. }
  1158. DbgWithLink(LOG_LEVEL_INFO, ctx->link.checkEmpty() ? LOG_TYPE_SYSTEM : LOG_TYPE_USER).setLogCode("QLR040220610")("计算校验码成功");
  1159. }
  1160. ctx->Answer(Error_Succeed);
  1161. return Error_Succeed;
  1162. }
  1163. ErrorCodeEnum CPinPadFSM::GetDevInfo(DevCategoryInfo &devInfo)
  1164. {
  1165. if (!m_bOpened)
  1166. return Error_DevNotAvailable;
  1167. //no need to do it again
  1168. if (!m_szModel.IsNullOrEmpty())
  1169. {
  1170. if (m_szModel.GetLength() > 1)
  1171. strncpy(devInfo.szModel, m_szModel.GetData(), m_szModel.GetLength());
  1172. if (m_szType.GetLength() > 1)
  1173. strncpy(devInfo.szType, m_szType.GetData(), m_szType.GetLength());
  1174. if (m_szVendor.GetLength() > 1)
  1175. strncpy(devInfo.szVendor, m_szVendor.GetData(), m_szVendor.GetLength());
  1176. return Error_Succeed;
  1177. }
  1178. DevCategoryInfo info;
  1179. ZeroMemory(info.szModel, MAX_DEV_MODEL_LEN);
  1180. ZeroMemory(info.szType, MAX_DEV_TYPE_LEN);
  1181. ZeroMemory(info.szVendor, MAX_DEV_VENDOR_LEN);
  1182. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  1183. ErrorCodeEnum eErrDev = m_hDevHelper->GetDevCategory(info);
  1184. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  1185. if (eErrDev == Error_Succeed)
  1186. {
  1187. m_szModel = info.szModel;
  1188. m_szType = info.szType;
  1189. m_szVendor = info.szVendor;
  1190. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::GetDevCategory").setCostTime(m_ullEndTime - m_ullBeginTime)
  1191. ("model,%d,%s;type,%d,%s;vendor,%d,%s", strlen(devInfo.szModel), m_szModel.GetData(), strlen(devInfo.szType), m_szType.GetData(), strlen(devInfo.szVendor), m_szVendor.GetData());
  1192. ZeroMemory(devInfo.szModel, MAX_DEV_MODEL_LEN);//CM=V2.0#PM=V1.0#MID=75500001#PID=12345678#FWID=V1234567#Vendor=nantian
  1193. ZeroMemory(devInfo.szType, MAX_DEV_TYPE_LEN);
  1194. ZeroMemory(devInfo.szVendor, MAX_DEV_VENDOR_LEN);
  1195. CSimpleStringA tmpModel("");
  1196. if (m_szModel.GetLength() > 1)
  1197. strncpy(devInfo.szModel, m_szModel.GetData(), m_szModel.GetLength());
  1198. if (m_szType.GetLength() > 1)
  1199. strncpy(devInfo.szType, m_szType.GetData(), m_szType.GetLength());
  1200. if (m_szVendor.GetLength() > 1)
  1201. strncpy(devInfo.szVendor, m_szVendor.GetData(), m_szVendor.GetLength());
  1202. }
  1203. else
  1204. {
  1205. SetErrorAndLog(eErrDev, MEC_DEVAPI_EPP_GetDevCategory, "DevAdapter::GetDevCategory", __FUNCTION__, false, m_ullEndTime - m_ullBeginTime);
  1206. m_szModel = "";
  1207. m_szType = "";
  1208. m_szVendor = "";
  1209. m_eDevState = DEVICE_STATUS_NOT_READY;
  1210. }
  1211. return eErrDev;
  1212. }
  1213. void CPinPadFSM::SetInWhatPage(int iPageType)
  1214. {
  1215. m_iInWhatPage = iPageType;
  1216. return;//oilyang@20200319 去掉任意情况下可输入
  1217. }
  1218. void CPinPadFSM::SelfTest(EntityTestEnum eTestType,CSmartPointer<ITransactionContext> pTransactionContext)
  1219. {
  1220. if (m_eDevState == DEVICE_STATUS_NORMAL)
  1221. pTransactionContext->SendAnswer(Error_Succeed);
  1222. else
  1223. {
  1224. if (m_bOpening)
  1225. pTransactionContext->SendAnswer(Error_Succeed);
  1226. else if (!m_bOpened)
  1227. pTransactionContext->SendAnswer(Error_DevNotAvailable);
  1228. else
  1229. pTransactionContext->SendAnswer(Error_InvalidState);
  1230. }
  1231. }
  1232. ErrorCodeEnum CPinPadFSM::GetEncryptTextJS(SpReqAnsContext<PinPadService_GetInputJS_Req, PinPadService_GetInputJS_Ans>::Pointer ctxJS)
  1233. {
  1234. LOG_FUNCTION();
  1235. ErrorCodeEnum errCode;
  1236. CSmartPointer<IEntityFunction> spEntityFunction = GetEntityBase()->GetFunction();
  1237. int timeout = ctxJS->Req.timeout;
  1238. AccountInfo accInfo;
  1239. memset(accInfo.account, 0, MAX_ACCOUNT_LEN);
  1240. CSimpleStringA errMsg(true);
  1241. if (Get12Account(const_cast<char*>(ctxJS->Req.account.GetData())))
  1242. memcpy(accInfo.account, m_szAccount + 4, 12);
  1243. else
  1244. {
  1245. errMsg = CSimpleStringA::Format("Get12Account err(%s).", (const char*)ctxJS->Req.account);
  1246. if (IsInBusiness())
  1247. {
  1248. DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_USER).setLogCode(PinPadService_LogCode_GetInputSM).setResultCode("RTA2607")(errMsg.GetData());
  1249. LogError(Severity_High, Error_Unexpect, PinPad_UserErrorCode_PinPad_GetEncryptText_Get12Account_Error, errMsg.GetData());
  1250. }
  1251. else
  1252. LogWarn(Severity_High, Error_Unexpect, PinPad_UserErrorCode_PinPad_GetEncryptText_Get12Account_Error, errMsg.GetData());
  1253. ctxJS->Answer(Error_DevCommFailed, PinPad_UserErrorCode_PinPad_GetEncryptText_Get12Account_Error);
  1254. return Error_DevCommFailed;
  1255. }
  1256. //memcpy(accInfo.account,"588571006555",12);
  1257. accInfo.dwAccLen = 12;
  1258. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("acc(%s)", accInfo.account);
  1259. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  1260. errCode = m_hDevHelper->SetAccNo(accInfo);
  1261. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  1262. if (errCode != Error_Succeed)
  1263. {
  1264. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("[sm]set accout(%s)(%s) failed(%d).", (const char*)ctxJS->Req.account, accInfo.account, errCode);
  1265. SetErrorAndLog(errCode, MEC_DEVAPI_EPP_SetAccNo, "DevAdapter::SetAccNo", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetInputSM);
  1266. ctxJS->Answer(Error_DevCommFailed, GetAlarmDEC());
  1267. return Error_DevCommFailed;
  1268. }
  1269. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::SetAccNo").setCostTime(m_ullEndTime - m_ullBeginTime)();
  1270. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  1271. errCode = m_hDevHelper->ActiveWorkingKey(1, 0);
  1272. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  1273. if (errCode != Error_Succeed)
  1274. {
  1275. SetErrorAndLog(errCode, MEC_DEVAPI_EPP_ActiveWorkingKey, "DevAdapter::ActiveWorkingKey", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetInputSM);
  1276. ctxJS->Answer(Error_DevCommFailed, GetAlarmDEC());
  1277. return Error_DevCommFailed;
  1278. }
  1279. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::ActiveWorkingKey").setCostTime(m_ullEndTime - m_ullBeginTime)();
  1280. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  1281. errCode = m_hDevHelper->SetParam(EPP_PT_SET_PIN_ALGORITH, EPP_PIN_ALGO_SM4);
  1282. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  1283. if (errCode != Error_Succeed)
  1284. {
  1285. SetErrorAndLog(errCode, MEC_DEVAPI_EPP_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetInputSM);
  1286. ctxJS->Answer(Error_DevCommFailed, GetAlarmDEC());
  1287. return Error_DevCommFailed;
  1288. }
  1289. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::SetParam").setCostTime(m_ullEndTime - m_ullBeginTime)();
  1290. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  1291. errCode = m_hDevHelper->StartPinInput(CurrentPasswordLen);
  1292. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  1293. if (errCode != Error_Succeed)
  1294. {
  1295. SetErrorAndLog(errCode, MEC_DEVAPI_EPP_StartPinInput, "DevAdapter::StartPinInput", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetInputSM);
  1296. DWORD dwCode = GetAlarmDEC();
  1297. ctxJS->Answer(Error_DevCommFailed, dwCode);
  1298. CSimpleStringA tmpRTA(true), tmpDesc(true);
  1299. if (GetEntityBase()->GetFunction()->GetVTMErrMsg(dwCode, tmpDesc, tmpRTA) == Error_Succeed)
  1300. DbgToBeidou(ctxJS->link, "GetEncryptTextJS").setReturnCode(tmpRTA)();
  1301. return Error_DevCommFailed;
  1302. }
  1303. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::StartPinInput").setCostTime(m_ullEndTime - m_ullBeginTime)();
  1304. DbgToBeidou(ctxJS->link, "GetEncryptTextJS")();
  1305. char* buf = new char[CurrentPasswordLen + 1];
  1306. memset(buf, 0, CurrentPasswordLen + 1);
  1307. int readed = 0;
  1308. DWORD elapsed = 0;
  1309. DWORD dwStart = SP::Module::Comm::RVCGetTickCount();
  1310. DWORD dwEnd = SP::Module::Comm::RVCGetTickCount();
  1311. bool bCancelInput = false;
  1312. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("req(pin),timeout:[%d]", timeout);
  1313. while (elapsed < MAX_PINPAD_INPUT_TIMEOUT) {
  1314. if (readed >= CurrentPasswordLen)
  1315. break;
  1316. if (m_bFrontCancel)
  1317. {
  1318. bCancelInput = true;
  1319. goto Err;
  1320. }
  1321. BYTE btCh;
  1322. Sleep(100);
  1323. errCode = m_hDevHelper->KeyRead(btCh);//循环调用,无需计算耗时
  1324. if (errCode == Error_Succeed) {
  1325. LogEvent(Severity_Middle, LOG_EVT_PINPAD_OP, "PinPad op.", ctxJS->link);
  1326. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("PinPad op: %d", readed);
  1327. if (btCh == 0x0d) {
  1328. dwEnd = SP::Module::Comm::RVCGetTickCount();
  1329. elapsed = dwEnd - dwStart;
  1330. continue;
  1331. }
  1332. else if (btCh == 0x08) { // back
  1333. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("clear input");
  1334. pop_char(buf, &readed, true);
  1335. }
  1336. else if (btCh == 0x1b) { // quit
  1337. bCancelInput = true;
  1338. goto Err;
  1339. }
  1340. else if (btCh == 0x3f) {
  1341. push_char(buf, &readed, '*');
  1342. }
  1343. else {
  1344. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("else[%d]", btCh);
  1345. }
  1346. }
  1347. else {
  1348. }
  1349. dwEnd = SP::Module::Comm::RVCGetTickCount();
  1350. elapsed = dwEnd - dwStart;
  1351. }
  1352. buf[readed] = 0;
  1353. Err:
  1354. if (buf != NULL)
  1355. delete[]buf;
  1356. if (bCancelInput)
  1357. {
  1358. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode("QLR040220602")("input cancel(pin)");
  1359. ctxJS->Answer(Error_Cancel);
  1360. return Error_Cancel;
  1361. }
  1362. if (readed < CurrentPasswordLen) {
  1363. if (elapsed >= MAX_PINPAD_INPUT_TIMEOUT) {
  1364. ctxJS->Answer(Error_TimeOut);
  1365. return Error_TimeOut;
  1366. }
  1367. }
  1368. PinBlock pinBlk;
  1369. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("to getpinblk");
  1370. Sleep(500);//nantian
  1371. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  1372. errCode = m_hDevHelper->GetPinBlock(pinBlk);
  1373. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  1374. LogWarn(Severity_Low, Error_Succeed, PinPad_UserErrorCode_PinPad_GetPinBlock_Call
  1375. , CSimpleStringA::Format("{\"cost\":%d}", m_ullEndTime - m_ullBeginTime));
  1376. if (errCode == Error_Succeed)
  1377. {
  1378. char* tmpPinData = new char[MAX_PIN_BLOCK_SIZE];
  1379. if (tmpPinData == NULL)
  1380. return Error_Resource;
  1381. memset(tmpPinData, 0, MAX_PIN_BLOCK_SIZE);
  1382. memcpy(tmpPinData, pinBlk.data, pinBlk.dwSize);
  1383. ctxJS->Ans.data = tmpPinData;
  1384. //Dbg("pinblk(%s)",tmpPinData);
  1385. if (tmpPinData != NULL)
  1386. {
  1387. delete[]tmpPinData;
  1388. tmpPinData = NULL;
  1389. }
  1390. EnDecryptInfo srcInfo, dstInfo;
  1391. memset(srcInfo.data, 0, MAX_EN_DECRYPT_DATA_SIZE);
  1392. memcpy(srcInfo.data, m_devCheckData, m_devCheckData.GetLength());
  1393. srcInfo.dwSize = m_devCheckData.GetLength();
  1394. memset(dstInfo.data, 0, MAX_EN_DECRYPT_DATA_SIZE);
  1395. //set param
  1396. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  1397. errCode = m_hDevHelper->SetParam(EPP_PT_SET_ENCRYPT_METHOD, EPP_ALGO_METHOD_SM4);
  1398. if (errCode == Error_Succeed)
  1399. errCode = m_hDevHelper->SetParam(EPP_PT_SET_ECB_CBC_MODE, EPP_ALGO_MODE_CBC);
  1400. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  1401. if (errCode != Error_Succeed)
  1402. {
  1403. SetErrorAndLog(errCode, MEC_DEVAPI_EPP_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetInputSM);
  1404. ctxJS->Answer(Error_Param, GetAlarmDEC());
  1405. return Error_Param;
  1406. }
  1407. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::SetParam").setCostTime(m_ullEndTime - m_ullBeginTime)();
  1408. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  1409. errCode = m_hDevHelper->EncryptData(srcInfo, dstInfo);
  1410. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  1411. if (errCode != Error_Succeed)
  1412. {
  1413. SetErrorAndLog(errCode, MEC_DEVAPI_EPP_EncryptData, "DevAdapter::EncryptData", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetInputSM);
  1414. ctxJS->Answer(Error_DevCommFailed, GetAlarmDEC());
  1415. return Error_DevCommFailed;
  1416. }
  1417. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::EncryptData").setCostTime(m_ullEndTime - m_ullBeginTime)();
  1418. char* tmpCheckCode = new char[MAX_PIN_BLOCK_SIZE];
  1419. if (tmpCheckCode == NULL)
  1420. return Error_Resource;
  1421. memset(tmpCheckCode, 0, MAX_PIN_BLOCK_SIZE);
  1422. //HexBuf2StrBuf(dstInfo.data,&tmpCheckCode,dstInfo.dwSize);
  1423. memcpy(tmpCheckCode, dstInfo.data, dstInfo.dwSize);
  1424. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ckckck[%s], m_keySNSM:%s", tmpCheckCode, m_keySNSM.GetData());
  1425. if (strnicmp(tmpCheckCode, "9F1F7BFF6F5511384D9430531E538FD3", strlen("9F1F7BFF6F5511384D9430531E538FD3")) == 0)
  1426. SetErrorAndLog(Error_Unexpect, PinPad_UserErrorCode_KEY_LOST_SM, "", __FUNCTION__);
  1427. ctxJS->Ans.checkcode = tmpCheckCode;
  1428. ctxJS->Ans.deviceno = m_deviceNo;
  1429. ctxJS->Ans.keyseq = m_keySNSM;
  1430. CSimpleStringA tmpLastCkCode = m_lastCheckCode;
  1431. if (m_lastCheckCode.IsNullOrEmpty() || strnicmp(tmpCheckCode, m_lastCheckCode, m_lastCheckCode.GetLength()) != 0)
  1432. {
  1433. ErrorCodeEnum eErr;
  1434. CSmartPointer<IConfigInfo> spConfigRun;
  1435. eErr = GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spConfigRun);
  1436. if (eErr == Error_Succeed)
  1437. {
  1438. spConfigRun->WriteConfigValue("Load", "ckckck", tmpCheckCode);
  1439. m_lastCheckCode = tmpCheckCode;
  1440. }
  1441. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("write ckckck:%s", tmpCheckCode);
  1442. }
  1443. if (!tmpLastCkCode.IsNullOrEmpty() && strnicmp(tmpCheckCode, tmpLastCkCode, tmpLastCkCode.GetLength()) != 0)
  1444. {
  1445. CSimpleStringA xCkChangeMsg = CSimpleStringA::Format("last ck:%s,current ck:%s,m_keySNSM:%s", tmpLastCkCode.GetData()
  1446. , tmpCheckCode, m_keySNSM.GetData());
  1447. LogWarn(Severity_Low, Error_Unexpect, PinPad_UserErrorCode_PinPad_CheckCode_Changed, xCkChangeMsg.GetData());
  1448. }
  1449. }
  1450. else
  1451. {
  1452. SetErrorAndLog(errCode, MEC_DEVAPI_EPP_GetPinBlock, "DevAdapter::GetPinBlock", __FUNCTION__, IsInBusiness(), m_ullEndTime - m_ullBeginTime, PinPadService_LogCode_GetInputSM);
  1453. ctxJS->Answer(Error_DevCommFailed, GetAlarmDEC());
  1454. return Error_DevCommFailed;
  1455. }
  1456. DbgWithLink(LOG_LEVEL_INFO, ctxJS->link.checkEmpty() ? LOG_TYPE_SYSTEM : LOG_TYPE_USER).setLogCode(PinPadService_LogCode_GetInputSM)
  1457. .setAPI("DevAdapter::GetPinBlock").setCostTime(m_ullEndTime - m_ullBeginTime)("获取密文成功");
  1458. //oilyang@20240410 move to out space,after stopinput & turn off the light
  1459. //Sleep(100);
  1460. //ctxSM->Answer(Error_Succeed);
  1461. return Error_Succeed;
  1462. }
  1463. int CPinPadFSM::GetInputJS(SpReqAnsContext<PinPadService_GetInputJS_Req, PinPadService_GetInputJS_Ans>::Pointer ctxJS)
  1464. {
  1465. DWORD dwCurrThId = GetCurrentThreadId();
  1466. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("GetInput thread id:%d", dwCurrThId);
  1467. m_bFrontCancel = false;
  1468. LogEvent(Severity_Middle, LOG_EVT_PINPAD_GREEN_ON, "PinPad light on.");
  1469. if (!m_hDevHelper)
  1470. {
  1471. SetErrorAndLog(Error_Unexpect, PinPad_UserErrorCode_PinPad_Instance_Is_Null, "", __FUNCTION__, false, 0, PinPadService_LogCode_GetInputSM);
  1472. m_inputJSCtx->Answer(Error_Unexpect, GetAlarmDEC());
  1473. LogEvent(Severity_Middle, LOG_EVT_PINPAD_GREEN_OFF, "PinPad light off.");
  1474. m_bPinInputJS = false;
  1475. return 1;
  1476. }
  1477. ULLINT ullGetInputBegin = SP::Module::Comm::RVCGetTickCount();
  1478. ErrorCodeEnum eErrCode = GetEncryptTextJS(m_inputJSCtx);
  1479. m_ullBeginTime = SP::Module::Comm::RVCGetTickCount();
  1480. ErrorCodeEnum errClosePinPad = m_hDevHelper->StopInput();
  1481. m_ullEndTime = SP::Module::Comm::RVCGetTickCount();
  1482. if (errClosePinPad != Error_Succeed)
  1483. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI("DevAdapter::StopInput").setResultCode("RTA2614").setCostTime(m_ullEndTime - m_ullBeginTime)("close pinpad(%s).", SpStrError(errClosePinPad));
  1484. else
  1485. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::StopInput").setCostTime(m_ullEndTime - m_ullBeginTime)("StopInput cost(%d)ms", m_ullEndTime - m_ullBeginTime);
  1486. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)
  1487. ("req acc.len:%d,ans.ck.len:%d", m_inputJSCtx->Req.account.GetLength(), m_inputJSCtx->Ans.checkcode.IsNullOrEmpty() ? 0 : m_inputJSCtx->Ans.checkcode.GetLength());
  1488. DbgToBeidou(m_inputJSCtx->link, "GetInput")();
  1489. m_bPinInput = false;
  1490. LogEvent(Severity_Middle, LOG_EVT_PINPAD_GREEN_OFF, "PinPad light off.");
  1491. if (eErrCode == Error_Succeed)
  1492. {
  1493. ULLINT ullGetInputEnd = SP::Module::Comm::RVCGetTickCount();
  1494. LogWarn(Severity_Low, Error_Unexpect, PinPad_UserErrorCode_GetInput_TimeCost, CSimpleStringA::Format("%d", (ullGetInputEnd - ullGetInputBegin) / 1000));
  1495. m_inputJSCtx->Answer(Error_Succeed);
  1496. }
  1497. return 0;
  1498. }