PinPadFSM.cpp 66 KB

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