HSPScannerFSM.cpp 89 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537
  1. #include "stdafx.h"
  2. #include "HSPScannerFSM.h"
  3. #include "EventCode.h"
  4. #include "CommDevEntityErrorCode.h"
  5. #include "RVCComm.h"
  6. #include "publicFunExport.h"
  7. #include "fileutil.h"
  8. #include <math.h>
  9. #ifndef _WIN32
  10. #include <winpr/sysinfo.h>
  11. #include "opencv.hpp"
  12. #else
  13. #include <opencv2/opencv.hpp>
  14. #endif //NOT _WIN32
  15. #define RESET_TIMER_ID 1
  16. #define CHECK_CONNECT_TIMER_ID 2
  17. const int MILLISECOND_TO_RESET = 30 * 1000;
  18. const int MILLISECOND_TO_CHECK_CONNECT = 15 * 1000;
  19. const int MAX_PATH_SIZE = 256;
  20. const int MAX_IMAGEDATA_BUFSIZE = 1 * 1024 * 1024;
  21. const int MAX_IMAGEDATA_SUFFIX = 1024;
  22. const int MAX_ERROR_TIMES = 2;
  23. #define TEMP_WIDTH 1280
  24. #define T_STRINGY(var) case var: return #var; break;
  25. const char* EvtTypeToString(int nEvtType)
  26. {
  27. switch (nEvtType)
  28. {
  29. T_STRINGY(USER_EVT_STARTPREVIEW)
  30. T_STRINGY(USER_EVT_STARTPREVIEW_FINISHED)
  31. T_STRINGY(USER_EVT_STOPPREVIEW)
  32. T_STRINGY(USER_EVT_STOPPREVIEW_FINISHED)
  33. T_STRINGY(USER_EVT_SETWINPOS)
  34. T_STRINGY(USER_EVT_SETWINPOSFINISHED)
  35. T_STRINGY(USER_EVT_SCANIMAGE)
  36. T_STRINGY(USER_EVT_SCANIMAGE_EX)
  37. T_STRINGY(USER_EVT_SCANIMAGEFINISHED)
  38. T_STRINGY(USER_EVT_SETPROPERTY)
  39. T_STRINGY(USER_EVT_SETPROPERTY_FINISHED)
  40. T_STRINGY(USER_EVT_GETSTATUS)
  41. T_STRINGY(USER_EVT_GETINFO)
  42. T_STRINGY(USER_EVT_DISCONNECT)
  43. T_STRINGY(USER_EVT_EXIT)
  44. T_STRINGY(USER_EVT_QUIT)
  45. T_STRINGY(USER_EVT_RESET)
  46. T_STRINGY(USER_EVT_EXIT_FINISHED)
  47. T_STRINGY(USER_EVT_SHOWPROPERTY)
  48. T_STRINGY(USER_EVT_SHOWPROPERTY_FINISHED)
  49. T_STRINGY(EVT_TIMER)
  50. T_STRINGY(USER_EVT_SETPROPERTYINVIEW_FINISHED)
  51. T_STRINGY(USER_EVT_NOCFG)
  52. T_STRINGY(USER_EVT_HIDEPREVIEW)
  53. T_STRINGY(USER_EVT_GOTOHELL)
  54. T_STRINGY(USER_EVT_STARTPREVIEW_JS)
  55. T_STRINGY(USER_EVT_STARTPREVIEW_JS_DONE)
  56. T_STRINGY(USER_EVT_CANCELPREVIEW_JS)
  57. T_STRINGY(USER_EVT_CANCELPREVIEW_JS_DONE)
  58. T_STRINGY(USER_EVT_SCANIMAGE_JS)
  59. T_STRINGY(USER_EVT_SCANIMAGE_JS_DONE)
  60. T_STRINGY(USER_EVT_SETPARAM_JS)
  61. default:
  62. return "Unknown EventType";
  63. break;
  64. }
  65. }
  66. const char* ParamValToString(int nParamVal)
  67. {
  68. switch (nParamVal)
  69. {
  70. T_STRINGY(HSPS_BOOLVAL_FALSE)
  71. T_STRINGY(HSPS_BOOLVAL_TRUE)
  72. T_STRINGY(HSPS_COLOR_FULL)
  73. T_STRINGY(HSPS_COLOR_GREY)
  74. T_STRINGY(HSPS_ROTATE_NOANGLE)
  75. T_STRINGY(HSPS_ROTATE_LEFT)
  76. T_STRINGY(HSPS_ROTATE_MIRROR)
  77. T_STRINGY(HSPS_ROTATE_RIGHT)
  78. T_STRINGY(HSPS_SCAN_FULL)
  79. T_STRINGY(HSPS_SCAN_A4)
  80. T_STRINGY(HSPS_SCAN_IDCARD)
  81. T_STRINGY(HSPS_VIEW_HIDE)
  82. T_STRINGY(HSPS_VIEW_SHOW)
  83. default:
  84. return "Unknown ParamVal";
  85. }
  86. }
  87. #undef T_STRINGY
  88. LPCTSTR CHSPScannerFSM::MapCode2RTAString(DWORD dwValue)
  89. {
  90. switch (dwValue) {
  91. case LOG_ERR_HSPS_DEVOPEN_FAILED:
  92. return "RTA2N01";
  93. break;
  94. case 0x21700002://跟灯事件有冲突
  95. return "RTA2N02";
  96. break;
  97. case LOG_ERR_HSPS_PREVIEW_FAILED: //跟灯事件有冲突
  98. return "RTA2N03";
  99. break;
  100. case LOG_EVT_HSPS_CANCEL_PREVIEW_FAILED:
  101. return "RTA2N04";
  102. break;
  103. case LOG_EVT_HSPS_SCANIMAGE_FAILED:
  104. return "RTA2N05";
  105. break;
  106. case LOG_EVT_HSPS_READ_IMAGEEX_FILE_FAILED:
  107. return "RTA2N06";
  108. break;
  109. case HSPScanner_UserErrorCode_SetParam_Position:
  110. return "RTA2N07";
  111. break;
  112. case 0x21700008:
  113. return "RTA2N08";
  114. break;
  115. case 0x21700009:
  116. return "RTA2N09";
  117. break;
  118. case 0x2170000A:
  119. return "RTA2N0A";
  120. break;
  121. case 0x2170000B:
  122. return "RTA2N0B";
  123. break;
  124. case 0x2170000C:
  125. return "RTA2N0C";
  126. break;
  127. case HSPScanner_UserErrorCode_READ_IMAGE_FILE_FAILED:
  128. return "RTA2N0D";
  129. break;
  130. case HSPScanner_UserErrorCode_LOAD_DLLFILE_NOTEIXT:
  131. return "RTA2N0E";
  132. break;
  133. case HSPScanner_UserErrorCode_LOAD_DLLFILE_FAILED:
  134. return "RTA2N0F";
  135. break;
  136. case HSPScanner_UserErrorCode_FSM_INVALID:
  137. return "RTA2N0G";
  138. break;
  139. case HSPScanner_UserErrorCode_DLLNAME_FAILED:
  140. return "RTA2N0H";
  141. break;
  142. case HSPScanner_UserErrorCode_DLLNAME_NOCFG:
  143. return "RTA2N0J";
  144. break;
  145. case HSPScanner_UserErrorCode_DEVICE_OFFLINE:
  146. return "RTA2N0K";
  147. break;
  148. case HSPScanner_UserErrorCode_IMAGE_CLEAR:
  149. return "RTA2N0L";
  150. break;
  151. case HSPScanner_UserErrorCode_CLEAR_RESOURCE_FAILED:
  152. return "RTA2N0L";
  153. break;
  154. case HSPScanner_UserErrorCode_NOT_SUPPORT:
  155. return "RTA2N0M";
  156. break;
  157. case LOG_WARN_HSPS_RESIZE_IMAGE_FILE_FAILED:
  158. return "RTA2N0N";
  159. break;
  160. case HSPScanner_UserErrorCode_SetParam_Hide:
  161. return "RTA2N0Q";
  162. break;
  163. case LOG_WARN_HSPS_INVALID_OPERATION:
  164. return "RTA2N0V";
  165. break;
  166. case HSPScanner_UserErrorCode_SetParam_View:
  167. return "RTA2N0R";
  168. break;
  169. /*RTA2N0S*/
  170. /*RTA2N0T*/
  171. /** 新增 [Gifur@20241111]*/
  172. case HSPScanner_UserErrorCode_SetParam_Color:
  173. return "RTA2N0W";
  174. break;
  175. case HSPScanner_UserErrorCode_SetParam_Rotate:
  176. return "RTA2N0Y";
  177. break;
  178. case HSPScanner_UserErrorCode_SetParam_Scan:
  179. return "RTA2N0Z";
  180. break;
  181. case LOG_WARN_HSPS_OPENING_NOW:
  182. return "RTA2N11";
  183. break;
  184. case 0:
  185. default:
  186. return "SUC0000";
  187. break;
  188. }
  189. }
  190. ParamTypeValue Param_Color_Map[4] = { HSPS_COLOR_FULL, HSPS_COLOR_FULL , HSPS_COLOR_GREY , HSPS_COLOR_FULL };
  191. ParamTypeValue Param_Rotate_Map[5] = { HSPS_ROTATE_NOANGLE, HSPS_ROTATE_NOANGLE , HSPS_ROTATE_LEFT , HSPS_ROTATE_MIRROR,HSPS_ROTATE_RIGHT };
  192. ParamTypeValue Param_Scan_Map[4] = { HSPS_SCAN_FULL, HSPS_SCAN_FULL , HSPS_SCAN_A4 , HSPS_SCAN_IDCARD };
  193. ParamTypeValue Param_View_Map[3] = { HSPS_VIEW_SHOW, HSPS_VIEW_SHOW , HSPS_VIEW_HIDE };
  194. CSimpleStringA CombineJsonContext(const char* szMessage)
  195. {
  196. CSimpleStringA result(true);
  197. if (szMessage == NULL || strlen(szMessage) == 0) {
  198. return result;
  199. }
  200. result = CSimpleStringA::Format("{\"addition\": \"%s\"}", szMessage);
  201. return result;
  202. }
  203. CHSPScannerFSM::CHSPScannerFSM(void)
  204. :
  205. m_ecSelfTest(Error_Succeed),
  206. m_nFatalTimes(0),
  207. m_nSrcState(sIdle),
  208. m_desiredAction(USER_EVT_QUIT),
  209. dwLastUserCode(0),
  210. m_dwMaxImageSize(500)
  211. {
  212. HARDWARE_ENTITY_RESET_ENTITYID(m_entCode, 0x217);
  213. m_FirstStart = TRUE;
  214. }
  215. CHSPScannerFSM::~CHSPScannerFSM(void)
  216. {
  217. }
  218. ErrorCodeEnum CHSPScannerFSM::OnInit()
  219. {
  220. ErrorCodeEnum erroCode = Error_Succeed;
  221. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Source Code complied at: %s %s", __DATE__, __TIME__);
  222. InitialMaxResizeValue();
  223. auto pEntity = GET_DEV_ENTITY_BASE_POINTER();
  224. pEntity->InitializeVendorLogSwitch();
  225. CSimpleStringA strNoUse(true);
  226. auto result = pEntity->ExtractVendorLibFullPath(strNoUse);
  227. if (result == Error_NotConfig) {
  228. PostEventLIFO(new FSMEvent(USER_EVT_NOCFG));
  229. SetDevInitingFlag(false);
  230. return Error_Succeed;
  231. }
  232. if (FAILURED(result)) {
  233. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Fetch Vendor dllName failed %s(%s).", (LPCTSTR)strNoUse, SpStrError(result));
  234. goto FAIL;
  235. }
  236. FulfillAdapterInfoFrom(pEntity->vendorLibInfo);
  237. LogWarn(Severity_Low, Error_Unexpect, HSPScanner_UserErrorCode_ROOT_INFO, (LPCTSTR)m_adapterInfo.adapterFilePath);
  238. erroCode = LoadUpAdapterLibrary();
  239. if (erroCode == Error_Succeed) {
  240. if (Error_Succeed == (erroCode = TryToOpenDevice())) {
  241. SetDevInitFlag(true);
  242. SetDevState(DEVICE_STATUS_NORMAL);
  243. SetDevInitingFlag(false);
  244. return erroCode;
  245. }
  246. }
  247. else if (erroCode == Error_NotExist) {
  248. SetLastUserCode(HSPScanner_UserErrorCode_LOAD_DLLFILE_NOTEIXT);
  249. }
  250. else {
  251. SetLastUserCode(HSPScanner_UserErrorCode_LOAD_DLLFILE_FAILED);
  252. }
  253. FAIL:
  254. SetDevInitFlag(false);
  255. SetDevInitingFlag(false);
  256. PostEventLIFO(new FSMEvent(USER_EVT_GOTOHELL));
  257. return Error_Succeed;
  258. }
  259. ErrorCodeEnum CHSPScannerFSM::TryToOpenDevice()
  260. {
  261. ErrorCodeEnum result(Error_Succeed);
  262. ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  263. result = m_hDevHelper->DevOpen();
  264. ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  265. if (FAILURED(result)) {
  266. //RTA2N01 / 21700001
  267. SetErrorAndLog(result, MEC_DEVAPI_HSPSCANNER_DevOpen, "DevAdapter::DevOpen", __FUNCTION__, false, ullEnd - ullStart);
  268. SetLastUserCode(LOG_ERR_HSPS_DEVOPEN_FAILED);
  269. }
  270. else {
  271. SetLastUserCode();
  272. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::DevOpen").setCostTime(ullEnd - ullStart)("Open HSPS succ");
  273. ullStart = SP::Module::Comm::RVCGetTickCount();
  274. result = FulfillAdapterDevCategory();
  275. ullEnd = SP::Module::Comm::RVCGetTickCount();
  276. if (result != Error_Succeed) {
  277. SetErrorAndLog(result, MEC_DEVAPI_HSPSCANNER_GetDevCategory, "DevAdapter::GetDevCategory", "FulfillAdapterDevCategory", false, ullEnd - ullStart);
  278. }
  279. m_nRecX = 0;
  280. m_nRecY = 224;
  281. m_nRecW = 1024;
  282. ErrorCodeEnum ecInit = m_hDevHelper->SetViewPos(m_nRecX, m_nRecY, m_nRecW);
  283. ErrorCodeEnum ecInitScan = m_hDevHelper->SetParam(HSPS_MODEL_SCANSIZE, HSPS_SCAN_FULL);
  284. ErrorCodeEnum ecInitRotate = m_hDevHelper->SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_NOANGLE);
  285. ErrorCodeEnum ecInitColor = m_hDevHelper->SetParam(HSPS_MODEL_COLOR, HSPS_COLOR_FULL);
  286. if (FAILURED(ecInit) || FAILURED(ecInitScan) || FAILURED(ecInitRotate) || FAILURED(ecInitColor)) {
  287. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("ViewPos: %s, Scan: %s, rotate: %s, color: %s.", SpStrError(ecInit), SpStrError(ecInitScan), SpStrError(ecInitRotate), SpStrError(ecInitColor));
  288. }
  289. }
  290. return result;
  291. }
  292. ErrorCodeEnum CHSPScannerFSM::OnExit()
  293. {
  294. if (m_hDevHelper) {
  295. ErrorCodeEnum errCode = Error_Succeed;
  296. m_hDevHelper.TearDown();
  297. return errCode;
  298. }
  299. return Error_Succeed;
  300. }
  301. void CHSPScannerFSM::s0_Idle_on_entry()
  302. {
  303. m_nFatalTimes = 0;
  304. m_ecSelfTest = Error_Succeed;
  305. }
  306. void CHSPScannerFSM::s0_Idle_on_exit()
  307. {
  308. }
  309. unsigned int CHSPScannerFSM::s0_Idle_on_event(FSMEvent* e)
  310. {
  311. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s0_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
  312. unsigned int uRet = 0;
  313. switch (e->iEvt)
  314. {
  315. /** JS Component [Gifur@20241113]*/
  316. case USER_EVT_STARTPREVIEW_JS:
  317. {
  318. JS::StartPreviewTask* pTask = new JS::StartPreviewTask(this);
  319. JS::StartPreviewEvent* pEvt = dynamic_cast<JS::StartPreviewEvent*>(e);
  320. pTask->SetContext(pEvt->m_ctx);
  321. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  322. e->SetHandled();
  323. }
  324. break;
  325. case USER_EVT_STARTPREVIEW_JS_DONE:
  326. {
  327. uRet = e->param1;
  328. e->SetHandled();
  329. }
  330. break;
  331. case USER_EVT_CANCELPREVIEW_JS:
  332. {
  333. //空闲状态收到取消预览的请求,直接返回成功
  334. JS::CancelPreviewEvent* pEvt = dynamic_cast<JS::CancelPreviewEvent*>(e);
  335. pEvt->m_ctx->Answer(Error_Succeed);
  336. e->SetHandled();
  337. }
  338. break;
  339. case USER_EVT_SETPARAM_JS:
  340. {
  341. JS::SetParamTask* pTask = new JS::SetParamTask(this);
  342. JS::SetParamEvent* pEvt = dynamic_cast<JS::SetParamEvent*>(e);
  343. pTask->SetContext(pEvt->m_ctx);
  344. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  345. e->SetHandled();
  346. }
  347. break;
  348. /** JS Component Done [Gifur@20241113]*/
  349. case USER_EVT_STARTPREVIEW:
  350. {
  351. StartPreviewTask* pTask = new StartPreviewTask(this);
  352. StartPreviewEvent* pEvt = dynamic_cast<StartPreviewEvent*>(e);
  353. pTask->SetContext(pEvt->m_ctx);
  354. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  355. e->SetHandled();
  356. }
  357. break;
  358. case USER_EVT_STARTPREVIEW_FINISHED:
  359. {
  360. uRet = e->param1;
  361. e->SetHandled();
  362. if(uRet == 1 && ++m_nFatalTimes <= MAX_ERROR_TIMES)
  363. {
  364. uRet = 2;
  365. }
  366. else if(uRet == 0)
  367. {
  368. m_nFatalTimes = 0;
  369. }
  370. if(uRet == 2 && IsDevConnected() == 0)
  371. {
  372. PostEventFIFO(new FSMEvent(USER_EVT_DISCONNECT));
  373. }
  374. else if(uRet == 1) {
  375. m_desiredAction = USER_EVT_STARTPREVIEW;
  376. }
  377. }
  378. break;
  379. // Add after ST !!! --Josephus at 12:37:15 2016129
  380. case USER_EVT_SETWINPOS:
  381. {
  382. SetWinPosEvent* pEvt = dynamic_cast<SetWinPosEvent*>(e);
  383. if(pEvt->m_ctx->Req.type == 2)
  384. {//在s0状态,仅能用于设置位置和窗体大小
  385. SetWinPosTask* pTask = new SetWinPosTask(this);
  386. pTask->SetContext(pEvt->m_ctx);
  387. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  388. e->SetHandled();
  389. }
  390. }
  391. break;
  392. case USER_EVT_SETPROPERTY:
  393. {
  394. SetPropertyEvent* pEvt = dynamic_cast<SetPropertyEvent*>(e);
  395. SetProperty(pEvt->m_ctx);
  396. e->SetHandled();
  397. }
  398. break;
  399. case USER_EVT_DISCONNECT:
  400. {
  401. //jump auto.
  402. }
  403. e->SetHandled();
  404. break;
  405. case USER_EVT_GETSTATUS:
  406. {
  407. GetDevStatusTask* pTask = new GetDevStatusTask(this);
  408. GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
  409. pTask->SetContext(pEvt->m_ctx);
  410. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  411. }
  412. e->SetHandled();
  413. break;
  414. case USER_EVT_GETINFO:
  415. {
  416. GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
  417. GetDevInfoTask* pTask = new GetDevInfoTask(this);
  418. pTask->SetContext(pEvt->m_ctx);
  419. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  420. }
  421. e->SetHandled();
  422. break;
  423. case USER_EVT_NOCFG:
  424. e->SetHandled();
  425. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("HSPScaner is not cofig now.");
  426. break;
  427. case USER_EVT_EXIT:
  428. {
  429. e->SetHandled();
  430. //TODO: Clear [Gifur@2025318]
  431. CSimpleStringA strNoUsed(true);
  432. GetCurImageName(strNoUsed);
  433. DelAndGetNewFileName(strNoUsed);
  434. GetCurImageName(strNoUsed, true);
  435. DelAndGetNewFileName(strNoUsed);
  436. }
  437. break;
  438. case USER_EVT_GOTOHELL:
  439. e->SetHandled();
  440. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("HSPScaner init failed!");
  441. break;
  442. default:
  443. {
  444. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("UnHandle event ! %d", e->iEvt);
  445. }
  446. break;
  447. }
  448. return uRet;
  449. }
  450. void CHSPScannerFSM::s1_Preview_on_entry()
  451. {
  452. LOG_FUNCTION();
  453. }
  454. void CHSPScannerFSM::s1_Preview_on_exit()
  455. {
  456. }
  457. unsigned int CHSPScannerFSM::s1_Preview_on_event(FSMEvent* e)
  458. {
  459. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s1_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
  460. unsigned int uRet = 0;
  461. switch (e->iEvt)
  462. {
  463. /** JS Component [Gifur@20241113]*/
  464. case USER_EVT_STARTPREVIEW_JS:
  465. {
  466. JS::StartPreviewEvent* pEvt = dynamic_cast<JS::StartPreviewEvent*>(e);
  467. if (JS::PreviewSettings(pEvt->m_ctx->Req).IsWorth()) {
  468. ErrorCodeEnum erroCode = SetPreviewProperty(JS::PreviewSettings(pEvt->m_ctx->Req), HSPScannerService_LogCode_StartPreviewJS);
  469. if (FAILURED(erroCode)) {
  470. pEvt->m_ctx->Answer(Error_Unexpect, GetLastUserCode());
  471. }
  472. else {
  473. pEvt->m_ctx->Answer(Error_Succeed);
  474. }
  475. }
  476. else {
  477. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("Require to preview when in previewing!!");
  478. pEvt->m_ctx->Answer(Error_Succeed);
  479. }
  480. e->SetHandled();
  481. }
  482. break;
  483. case USER_EVT_CANCELPREVIEW_JS:
  484. {
  485. JS::CancelPreviewTask* pTask = new JS::CancelPreviewTask(this);
  486. JS::CancelPreviewEvent* pEvt = dynamic_cast<JS::CancelPreviewEvent*>(e);
  487. pTask->SetContext(pEvt->m_ctx);
  488. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  489. e->SetHandled();
  490. }
  491. break;
  492. case USER_EVT_CANCELPREVIEW_JS_DONE:
  493. {
  494. if (e->param1 == 0) {
  495. if (e->param2 == 1) uRet = 2;
  496. else uRet = 1;
  497. }
  498. e->SetHandled();
  499. }
  500. break;
  501. case USER_EVT_SCANIMAGE_JS:
  502. {
  503. JS::ScanImageTask* pTask = new JS::ScanImageTask(this);
  504. JS::ScanImageEvent* pEvt = dynamic_cast<JS::ScanImageEvent*>(e);
  505. pTask->SetContext(pEvt->m_ctx);
  506. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  507. e->SetHandled();
  508. }
  509. break;
  510. case USER_EVT_SCANIMAGE_JS_DONE:
  511. {
  512. if (e->param1 == 0) {
  513. if (e->param2 == 1) uRet = 2;
  514. else uRet = 1;
  515. }
  516. e->SetHandled();
  517. }
  518. break;
  519. case USER_EVT_SETPARAM_JS:
  520. {
  521. JS::SetParamTask* pTask = new JS::SetParamTask(this);
  522. JS::SetParamEvent* pEvt = dynamic_cast<JS::SetParamEvent*>(e);
  523. pTask->SetContext(pEvt->m_ctx);
  524. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  525. e->SetHandled();
  526. }
  527. break;
  528. /** JS Component Done [Gifur@20241113]*/
  529. case USER_EVT_STARTPREVIEW:
  530. {
  531. // Maybe Just SetProperty [Josephus in 15:44:43 2016/11/19]
  532. SetPropertyInPreviewTask* pTask = new SetPropertyInPreviewTask(this);
  533. StartPreviewEvent* pEvt = dynamic_cast<StartPreviewEvent*>(e);
  534. pTask->SetContext(pEvt->m_ctx);
  535. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  536. e->SetHandled();
  537. }
  538. break;
  539. case USER_EVT_SETPROPERTYINVIEW_FINISHED:
  540. {
  541. }
  542. e->SetHandled();
  543. break;
  544. case USER_EVT_STOPPREVIEW:
  545. {
  546. StopPreviewTask* pTask = new StopPreviewTask(this);
  547. StopPreviewEvent* pEvt = dynamic_cast<StopPreviewEvent*>(e);
  548. pTask->SetContext(pEvt->m_ctx);
  549. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  550. }
  551. e->SetHandled();
  552. break;
  553. case USER_EVT_STOPPREVIEW_FINISHED:
  554. {
  555. uRet = e->param1;
  556. if((uRet == 0 || uRet == 4) && ++m_nFatalTimes <= MAX_ERROR_TIMES)
  557. {
  558. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("hold on, wait next time (%d/%d).", m_nFatalTimes, MAX_ERROR_TIMES);
  559. uRet = 3;
  560. }
  561. else if(uRet != 0)
  562. {
  563. m_nFatalTimes = 0;
  564. }
  565. if(uRet == 3 && IsDevConnected() == 0)
  566. {
  567. PostEventFIFO(new FSMEvent(USER_EVT_DISCONNECT));
  568. }
  569. else if(uRet == 0) {
  570. m_desiredAction = USER_EVT_STOPPREVIEW;
  571. }
  572. else if(uRet == 4) {
  573. m_desiredAction = USER_EVT_HIDEPREVIEW;
  574. }
  575. }
  576. e->SetHandled();
  577. break;
  578. case USER_EVT_SCANIMAGE:
  579. {
  580. ScanImageTask* pTask = new ScanImageTask(this);
  581. ScanImageEvent* pEvt = dynamic_cast<ScanImageEvent*>(e);
  582. pTask->SetContext(pEvt->m_ctx);
  583. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  584. }
  585. e->SetHandled();
  586. break;
  587. case USER_EVT_SCANIMAGE_EX:
  588. {
  589. ScanImageExTask* pTask = new ScanImageExTask(this);
  590. ScanImageExEvent* pEvt = dynamic_cast<ScanImageExEvent*>(e);
  591. pTask->SetContext(pEvt->m_ctx);
  592. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  593. }
  594. e->SetHandled();
  595. break;
  596. case USER_EVT_SETPROPERTY:
  597. {
  598. SetPropertyEvent* pEvt = dynamic_cast<SetPropertyEvent*>(e);
  599. SetProperty(pEvt->m_ctx);
  600. }
  601. e->SetHandled();
  602. break;
  603. case USER_EVT_SHOWPROPERTY:
  604. {
  605. ShowPropertyTask* pTask = new ShowPropertyTask(this);
  606. ShowPropertyEvent* pEvt = dynamic_cast<ShowPropertyEvent*>(e);
  607. pTask->SetContext(pEvt->m_ctx);
  608. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  609. }
  610. e->SetHandled();
  611. break;
  612. case USER_EVT_SETWINPOS:
  613. {
  614. SetWinPosEvent* pEvt = dynamic_cast<SetWinPosEvent*>(e);
  615. SetWinPosTask* pTask = new SetWinPosTask(this);
  616. pTask->SetContext(pEvt->m_ctx);
  617. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  618. }
  619. e->SetHandled();
  620. break;
  621. case USER_EVT_DISCONNECT:
  622. {
  623. //jump auto.
  624. }
  625. e->SetHandled();
  626. break;
  627. case USER_EVT_GETSTATUS:
  628. {
  629. GetDevStatusTask* pTask = new GetDevStatusTask(this);
  630. GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
  631. pTask->SetContext(pEvt->m_ctx);
  632. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  633. }
  634. e->SetHandled();
  635. break;
  636. case USER_EVT_GETINFO:
  637. {
  638. GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
  639. GetDevInfoTask* pTask = new GetDevInfoTask(this);
  640. pTask->SetContext(pEvt->m_ctx);
  641. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  642. }
  643. e->SetHandled();
  644. break;
  645. }
  646. return uRet;
  647. }
  648. void CHSPScannerFSM::s2_on_entry()
  649. {
  650. LOG_FUNCTION();
  651. }
  652. void CHSPScannerFSM::s2_on_exit()
  653. {
  654. }
  655. unsigned int CHSPScannerFSM::s2_on_event(FSMEvent* e)
  656. {
  657. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s2_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
  658. unsigned int uRet = 0;
  659. switch(e->iEvt)
  660. {
  661. case USER_EVT_SHOWPROPERTY_FINISHED:
  662. {
  663. }
  664. e->SetHandled();
  665. break;
  666. case USER_EVT_GETSTATUS:
  667. {
  668. GetDevStatusTask* pTask = new GetDevStatusTask(this);
  669. GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
  670. pTask->SetContext(pEvt->m_ctx);
  671. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  672. }
  673. e->SetHandled();
  674. break;
  675. case USER_EVT_GETINFO:
  676. {
  677. GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
  678. GetDevInfoTask* pTask = new GetDevInfoTask(this);
  679. pTask->SetContext(pEvt->m_ctx);
  680. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  681. }
  682. e->SetHandled();
  683. break;
  684. }
  685. return uRet;
  686. }
  687. void CHSPScannerFSM::s3_Failed_on_entry()
  688. {
  689. LOG_FUNCTION();
  690. SetDevState(DEVICE_STATUS_FAULT);
  691. const int nStatus = IsDevConnected();
  692. if (nStatus == 0) {
  693. PostEventFIFO(new FSMEvent(USER_EVT_DISCONNECT));
  694. }
  695. else if (nStatus == -1) {
  696. //让自检握手触发实体重启
  697. }
  698. else {
  699. ScheduleTimer(RESET_TIMER_ID, MILLISECOND_TO_RESET / 6);
  700. }
  701. }
  702. void CHSPScannerFSM::s3_Failed_on_exit()
  703. {
  704. SetDevState(DEVICE_STATUS_NORMAL);
  705. m_ecSelfTest = Error_Succeed;
  706. m_nFatalTimes = 0;
  707. m_desiredAction = USER_EVT_QUIT;
  708. CancelTimer(RESET_TIMER_ID);
  709. }
  710. unsigned int CHSPScannerFSM::s3_Failed_on_event(FSMEvent* e)
  711. {
  712. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s3_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
  713. unsigned int uRet = 0;
  714. switch(e->iEvt)
  715. {
  716. /** JS Component [Gifur@20241112]*/
  717. case USER_EVT_STARTPREVIEW_JS:
  718. {
  719. JS::StartPreviewEvent* pEvt = dynamic_cast<JS::StartPreviewEvent*>(e);
  720. if (!m_bOpened) {
  721. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_StartPreviewJS).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
  722. pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
  723. e->SetHandled();
  724. }
  725. //TODO: [Gifur@2025318]
  726. }
  727. break;
  728. case USER_EVT_CANCELPREVIEW_JS:
  729. {
  730. JS::CancelPreviewEvent* pEvt = dynamic_cast<JS::CancelPreviewEvent*>(e);
  731. if (!m_bOpened) {
  732. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_CancelPreviewJS).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
  733. pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
  734. }
  735. else {
  736. pEvt->m_ctx->Answer(Error_Succeed);
  737. }
  738. e->SetHandled();
  739. }
  740. break;
  741. case USER_EVT_SCANIMAGE_JS:
  742. {
  743. JS::ScanImageEvent* pEvt = dynamic_cast<JS::ScanImageEvent*>(e);
  744. if (!m_bOpened) {
  745. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImageJS).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
  746. pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
  747. e->SetHandled();
  748. }//TODO: [Gifur@2025318]
  749. }
  750. break;
  751. case USER_EVT_SETPARAM_JS:
  752. {
  753. JS::SetParamEvent* pEvt = dynamic_cast<JS::SetParamEvent*>(e);
  754. if (!m_bOpened) {
  755. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_SetParamJS).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
  756. pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
  757. e->SetHandled();
  758. }
  759. else {
  760. JS::SetParamTask* pTask = new JS::SetParamTask(this);
  761. pTask->SetContext(pEvt->m_ctx);
  762. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  763. e->SetHandled();
  764. }
  765. }
  766. break;
  767. /** JS Compoent Done [Gifur@20241112]*/
  768. case USER_EVT_STARTPREVIEW:
  769. {
  770. StartPreviewEvent* pEvt = dynamic_cast<StartPreviewEvent*>(e);
  771. if (!m_bOpened) {
  772. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_StartPreview).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
  773. pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
  774. } else {
  775. StartPreviewTask* pTask = new StartPreviewTask(this);
  776. pTask->SetContext(pEvt->m_ctx);
  777. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  778. }
  779. e->SetHandled();
  780. }
  781. break;
  782. case USER_EVT_STARTPREVIEW_FINISHED:
  783. {
  784. uRet = e->param1;
  785. e->SetHandled();
  786. }
  787. break;
  788. case USER_EVT_STOPPREVIEW:
  789. {
  790. if(m_hDevHelper && m_bOpened)
  791. {
  792. CancelTimer(RESET_TIMER_ID);
  793. StopPreviewEvent* pEvt = dynamic_cast<StopPreviewEvent*>(e);
  794. HspsDevStatus status = {0};
  795. ErrorCodeEnum erroCode = GetDevStatusFromAdapter(status);
  796. if (status.inPreview == 1) {
  797. StopPreviewTask* pTask = new StopPreviewTask(this);
  798. pTask->SetContext(pEvt->m_ctx);
  799. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  800. } else if (status.inShow == 1) {
  801. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  802. erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
  803. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  804. if (ISSUCCEEDED(erroCode)) {
  805. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_CancelPreview).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)("HSPS_VIEW_HIDE");
  806. } else {
  807. //RTA2N0Q
  808. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_CancelPreview, CombineJsonContext("HSPS_VIEW_HIDE failed"));
  809. SetLastUserCode(GetAlarmDEC());
  810. }
  811. pEvt->m_ctx->Answer(TransECWithRepeat(erroCode));
  812. FSMEvent* timerEvent = new FSMEvent(EVT_TIMER);
  813. timerEvent->param1 = RESET_TIMER_ID;
  814. PostEventFIFO(timerEvent);
  815. }
  816. } else if (!m_bOpened) {
  817. StopPreviewEvent* pEvt = dynamic_cast<StopPreviewEvent*>(e);
  818. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_CancelPreview).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
  819. pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
  820. }
  821. }
  822. e->SetHandled();
  823. break;
  824. case USER_EVT_STOPPREVIEW_FINISHED:
  825. {
  826. uRet = e->param1;
  827. if(uRet == 0) {
  828. m_desiredAction = USER_EVT_STOPPREVIEW;
  829. }
  830. else if(uRet == 4) {
  831. m_desiredAction = USER_EVT_HIDEPREVIEW;
  832. }
  833. FSMEvent* timerEvent = new FSMEvent(EVT_TIMER);
  834. timerEvent->param1 = RESET_TIMER_ID;
  835. PostEventFIFO(timerEvent);
  836. }
  837. e->SetHandled();
  838. break;
  839. case USER_EVT_OPENSUCC:
  840. ///*TODO(80374374@9/2/2022): */
  841. e->SetHandled();
  842. break;
  843. case USER_EVT_RESET:
  844. {
  845. if (m_bOpened) {
  846. ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  847. ErrorCodeEnum erroCode = m_hDevHelper->Reset();
  848. ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  849. if (FAILURED(erroCode)) {
  850. //RTA2N0B
  851. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_Reset, "DevAdapter::Reset", __FUNCTION__, false, ullEnd - ullStart, HSPScannerService_CustomLogCode_Reset);
  852. m_ecSelfTest = Error_InvalidState;
  853. uRet = 1;
  854. } else {
  855. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::Reset").setCostTime(ullEnd - ullStart)("Reset");
  856. ullStart = SP::Module::Comm::RVCGetTickCount();
  857. ErrorCodeEnum eXYW = m_hDevHelper->SetViewPos(m_nRecX, m_nRecY, m_nRecW);
  858. ullEnd = SP::Module::Comm::RVCGetTickCount();
  859. if (FAILURED(eXYW)) {
  860. //RTA2N07
  861. SetErrorAndLog(eXYW, MEC_DEVAPI_HSPSCANNER_SetViewPos, "DevAdapter::SetViewPos", __FUNCTION__, false, ullEnd - ullStart, HSPScannerService_CustomLogCode_Reset);
  862. uRet = 1;
  863. m_ecSelfTest = Error_InvalidState;
  864. e->SetHandled();
  865. break;
  866. } else {
  867. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::SetViewPos").setCostTime(ullEnd - ullStart)("x:%d, y:%d, w:%d, err:%s", m_nRecX, m_nRecY, m_nRecW, SpStrError(eXYW));
  868. }
  869. HspsDevStatus status = {0};
  870. erroCode = GetDevStatusFromAdapter(status);
  871. if (status.inPreview == 1 && status.inShow == 1) {
  872. if (m_desiredAction == USER_EVT_STOPPREVIEW) {
  873. do
  874. {
  875. ullStart = SP::Module::Comm::RVCGetTickCount();
  876. erroCode = m_hDevHelper->SetPreview(0);
  877. ullEnd = SP::Module::Comm::RVCGetTickCount();
  878. if (erroCode == Error_Succeed) {
  879. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::CancelPreview").setCostTime(ullEnd - ullStart)();
  880. } else {
  881. //RTA2N04
  882. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetPreview_Close, "DevAdapter::CancelPreview", __FUNCTION__, false, ullEnd - ullStart, HSPScannerService_CustomLogCode_Reset);
  883. }
  884. } while (false);
  885. {
  886. HspsDevStatus retryStatus = { 0 };
  887. GetDevStatusFromAdapter(retryStatus);
  888. if (retryStatus.inPreview == 1) {
  889. do
  890. {
  891. ullStart = SP::Module::Comm::RVCGetTickCount();
  892. erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
  893. ullEnd = SP::Module::Comm::RVCGetTickCount();
  894. if (erroCode == Error_Succeed) {
  895. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)("HSPS_MODEL_VIEW, HSPS_VIEW_HIDE");
  896. } else {
  897. //RTA2N0Q
  898. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, false, ullEnd - ullStart, HSPScannerService_CustomLogCode_Reset, CombineJsonContext("HSPS_VIEW_HIDE"));
  899. }
  900. } while (false);
  901. }
  902. }
  903. } else if (m_desiredAction == USER_EVT_HIDEPREVIEW) {
  904. do
  905. {
  906. ullStart = SP::Module::Comm::RVCGetTickCount();
  907. erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
  908. ullEnd = SP::Module::Comm::RVCGetTickCount();
  909. if (erroCode == Error_Succeed) {
  910. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)("HSPS_VIEW_HIDE");
  911. } else {
  912. //RTA2N0Q
  913. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, false, ullEnd - ullStart, HSPScannerService_CustomLogCode_Reset, CombineJsonContext("HSPS_VIEW_HIDE"));
  914. }
  915. } while (false);
  916. }
  917. if (FAILURED(erroCode)) {
  918. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Recover failed under desiration of %s", EvtTypeToString(m_desiredAction));
  919. uRet = 1;
  920. m_ecSelfTest = Error_InvalidState;
  921. e->SetHandled();
  922. break;
  923. }
  924. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setLogCode(HSPScannerService_CustomLogCode_Reset)("Recover routine done");
  925. uRet = 2;
  926. }
  927. }
  928. }
  929. }
  930. e->SetHandled();
  931. break;
  932. case EVT_TIMER:
  933. {
  934. if (e->param1 == RESET_TIMER_ID) {
  935. FSMEvent* pEvt = new FSMEvent(USER_EVT_RESET);
  936. PostEventFIFO(pEvt);
  937. ScheduleTimer(RESET_TIMER_ID, MILLISECOND_TO_RESET);
  938. }
  939. }
  940. e->SetHandled();
  941. break;
  942. case USER_EVT_DISCONNECT:
  943. e->SetHandled();
  944. break;
  945. case USER_EVT_GETSTATUS:
  946. {
  947. GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
  948. if (!m_bOpened) {
  949. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevStatus).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
  950. pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
  951. } else {
  952. GetDevStatusTask* pTask = new GetDevStatusTask(this);
  953. pTask->SetContext(pEvt->m_ctx);
  954. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  955. }
  956. }
  957. e->SetHandled();
  958. break;
  959. case USER_EVT_GETINFO:
  960. {
  961. GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
  962. GetDevInfoTask* pTask = new GetDevInfoTask(this);
  963. pTask->SetContext(pEvt->m_ctx);
  964. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  965. }
  966. e->SetHandled();
  967. break;
  968. case USER_EVT_SETWINPOS:
  969. {
  970. SetWinPosEvent* pEvt = dynamic_cast<SetWinPosEvent*>(e);
  971. if (!m_bOpened) {
  972. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_SetWinPos).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
  973. pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
  974. e->SetHandled();
  975. }
  976. }
  977. break;
  978. }
  979. return uRet;
  980. }
  981. void CHSPScannerFSM::s4_ScanImage_on_entry()
  982. {
  983. }
  984. void CHSPScannerFSM::s4_ScanImage_on_exit()
  985. {
  986. }
  987. unsigned int CHSPScannerFSM::s4_ScanImage_on_event(FSMEvent* e)
  988. {
  989. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s4_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
  990. unsigned int uRet = 0;
  991. switch(e->iEvt)
  992. {
  993. /** JS Component [Gifur@20241114]*/
  994. //拍照应该是一瞬间的事情,这个状态很快会结束,这里不对事件进行处理,待实践中验证
  995. /** JS Component Done [Gifur@20241114]*/
  996. case USER_EVT_SCANIMAGEFINISHED:
  997. {
  998. uRet = e->param1;
  999. if(uRet == 2 && ++m_nFatalTimes < MAX_ERROR_TIMES)
  1000. {
  1001. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("hold on, wait next time (%d/%d).", m_nFatalTimes, MAX_ERROR_TIMES);
  1002. uRet = 5;
  1003. }
  1004. else if(uRet == 0)
  1005. {
  1006. m_nFatalTimes = 0;
  1007. }
  1008. if(uRet == 5 && IsDevConnected() == 0)
  1009. {
  1010. PostEventFIFO(new FSMEvent(USER_EVT_DISCONNECT));
  1011. }
  1012. else if(uRet == 2 || uRet == 4)
  1013. {
  1014. m_desiredAction = USER_EVT_SCANIMAGE;
  1015. }
  1016. }
  1017. e->SetHandled();
  1018. break;
  1019. case USER_EVT_DISCONNECT:
  1020. {
  1021. //jump auto.
  1022. }
  1023. e->SetHandled();
  1024. break;
  1025. case USER_EVT_GETSTATUS:
  1026. {
  1027. GetDevStatusTask* pTask = new GetDevStatusTask(this);
  1028. GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
  1029. pTask->SetContext(pEvt->m_ctx);
  1030. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  1031. }
  1032. e->SetHandled();
  1033. break;
  1034. case USER_EVT_GETINFO:
  1035. {
  1036. GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
  1037. GetDevInfoTask* pTask = new GetDevInfoTask(this);
  1038. pTask->SetContext(pEvt->m_ctx);
  1039. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  1040. }
  1041. e->SetHandled();
  1042. break;
  1043. }
  1044. return uRet;
  1045. }
  1046. void CHSPScannerFSM::s5_DeviceOff_on_entry()
  1047. {
  1048. SetDevState(DEVICE_STATUS_CONNECTING);
  1049. LogWarn(Severity_Low, Error_DevNotAvailable, HSPScanner_UserErrorCode_DEVICE_OFFLINE, "高拍仪断开连接!");
  1050. SetLastUserCode(HSPScanner_UserErrorCode_DEVICE_OFFLINE);
  1051. ScheduleTimer(CHECK_CONNECT_TIMER_ID, MILLISECOND_TO_CHECK_CONNECT);
  1052. }
  1053. void CHSPScannerFSM::s5_DeviceOff_on_exit()
  1054. {
  1055. SetLastUserCode();
  1056. SetDevState(DEVICE_STATUS_NORMAL);
  1057. CancelTimer(CHECK_CONNECT_TIMER_ID);
  1058. }
  1059. unsigned int CHSPScannerFSM::s5_DeviceOff_on_event(FSMEvent* e)
  1060. {
  1061. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s5_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
  1062. unsigned int uRet = 0;
  1063. switch(e->iEvt)
  1064. {
  1065. /** JS Component [Gifur@20241112]*/
  1066. case USER_EVT_STARTPREVIEW_JS:
  1067. {
  1068. JS::StartPreviewEvent* pEvt = dynamic_cast<JS::StartPreviewEvent*>(e);
  1069. pEvt->SetHandled();
  1070. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_StartPreviewJS).setResultCode(MapCode2RTAString(GetLastUserCode()))("OffLine meets USER_EVT_STARTPREVIEW_JS");
  1071. pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
  1072. }
  1073. break;
  1074. case USER_EVT_CANCELPREVIEW_JS:
  1075. {
  1076. JS::CancelPreviewEvent* pEvt = dynamic_cast<JS::CancelPreviewEvent*>(e);
  1077. pEvt->SetHandled();
  1078. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_CancelPreviewJS).setResultCode(MapCode2RTAString(GetLastUserCode()))("OffLine meets USER_EVT_CANCELPREVIEW_JS");
  1079. pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
  1080. }
  1081. break;
  1082. case USER_EVT_SCANIMAGE_JS:
  1083. {
  1084. JS::ScanImageEvent* pEvt = dynamic_cast<JS::ScanImageEvent*>(e);
  1085. pEvt->SetHandled();
  1086. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImageJS).setResultCode(MapCode2RTAString(GetLastUserCode()))("OffLine meets USER_EVT_SCANIMAGE_JS");
  1087. pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
  1088. }
  1089. break;
  1090. case USER_EVT_SETPARAM_JS:
  1091. {
  1092. JS::SetParamEvent* pEvt = dynamic_cast<JS::SetParamEvent*>(e);
  1093. pEvt->SetHandled();
  1094. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_SetParamJS).setResultCode(MapCode2RTAString(GetLastUserCode()))("OffLine meets USER_EVT_SETPARAM_JS");
  1095. pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
  1096. }
  1097. break;
  1098. /** JS Compoent Done [Gifur@20241112]*/
  1099. case EVT_TIMER:
  1100. {
  1101. if (e->param1 == CHECK_CONNECT_TIMER_ID) {
  1102. HspsDevStatus status = { 0 };
  1103. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  1104. ErrorCodeEnum eResult = m_hDevHelper->GetDevStatus(status);
  1105. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  1106. if (ISSUCCEEDED(eResult)) {
  1107. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::GetDevStatus").setCostTime(ullEnd - ullStart)("{\"connected\": %d, \"previewing\": %d, \"showing\": %d}", status.isConnected, status.inPreview, status.inShow);
  1108. if (status.isConnected == 0) {
  1109. ScheduleTimer(CHECK_CONNECT_TIMER_ID, MILLISECOND_TO_CHECK_CONNECT);
  1110. } else if (status.inShow == 1 && status.inPreview == 1) {
  1111. //回到预览状态
  1112. uRet = 2;
  1113. } else {
  1114. uRet = 1;
  1115. }
  1116. } else {
  1117. //RTA2N09
  1118. SetErrorAndLog(eResult, MEC_DEVAPI_HSPSCANNER_GetDevStatus, "DevAdapter::GetDevStatus", __FUNCTION__, false, ullEnd - ullStart);
  1119. }
  1120. e->SetHandled();
  1121. }
  1122. }
  1123. break;
  1124. case USER_EVT_GETSTATUS:
  1125. {
  1126. GetDevStatusTask* pTask = new GetDevStatusTask(this);
  1127. GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
  1128. pTask->SetContext(pEvt->m_ctx);
  1129. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  1130. }
  1131. e->SetHandled();
  1132. break;
  1133. case USER_EVT_GETINFO:
  1134. {
  1135. GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
  1136. GetDevInfoTask* pTask = new GetDevInfoTask(this);
  1137. pTask->SetContext(pEvt->m_ctx);
  1138. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  1139. }
  1140. e->SetHandled();
  1141. break;
  1142. case USER_EVT_SETWINPOS:
  1143. {
  1144. SetWinPosEvent* pEvt = dynamic_cast<SetWinPosEvent*>(e);
  1145. pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
  1146. }
  1147. e->SetHandled();
  1148. break;
  1149. }
  1150. return uRet;
  1151. }
  1152. void CHSPScannerFSM::s6_HidPreviewing_on_entry()
  1153. {
  1154. }
  1155. void CHSPScannerFSM::s6_HidPreviewing_on_exit()
  1156. {
  1157. }
  1158. unsigned int CHSPScannerFSM::s6_HidPreviewing_on_event(FSMEvent* e)
  1159. {
  1160. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s6_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
  1161. unsigned int uRet = 0;
  1162. switch(e->iEvt)
  1163. {
  1164. /*JS Component*/
  1165. case USER_EVT_STARTPREVIEW_JS:
  1166. {
  1167. JS::StartPreviewEvent* pEvt = dynamic_cast<JS::StartPreviewEvent*>(e);
  1168. HspsDevStatus status = { 0 };
  1169. GetDevStatusFromAdapter(status);
  1170. JS::PreviewSettings settings(pEvt->m_ctx->Req);
  1171. settings.SetDisplay(true);
  1172. ErrorCodeEnum erroCode = SetPreviewProperty(settings, HSPScannerService_LogCode_StartPreviewJS);
  1173. if (FAILURED(erroCode)) {
  1174. pEvt->m_ctx->Answer(Error_Unexpect, GetLastUserCode());
  1175. uRet = 0;
  1176. }
  1177. else {
  1178. pEvt->m_ctx->Answer(Error_Succeed);
  1179. uRet = 1;
  1180. }
  1181. e->SetHandled();
  1182. }
  1183. break;
  1184. case USER_EVT_CANCELPREVIEW_JS:
  1185. {
  1186. JS::CancelPreviewEvent* pEvt = dynamic_cast<JS::CancelPreviewEvent*>(e);
  1187. if (pEvt->m_ctx->Req.hide) {
  1188. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_CancelPreviewJS)("current state is already hide preview");
  1189. pEvt->m_ctx->Answer(Error_Succeed);
  1190. }
  1191. else {
  1192. JS::CancelPreviewTask* pTask = new JS::CancelPreviewTask(this);
  1193. pTask->SetContext(pEvt->m_ctx);
  1194. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  1195. }
  1196. e->SetHandled();
  1197. }
  1198. break;
  1199. case USER_EVT_STARTPREVIEW_JS_DONE:
  1200. {
  1201. uRet = e->param1;
  1202. e->SetHandled();
  1203. }
  1204. break;
  1205. case USER_EVT_SCANIMAGE_JS:
  1206. {
  1207. JS::ScanImageTask* pTask = new JS::ScanImageTask(this);
  1208. JS::ScanImageEvent* pEvt = dynamic_cast<JS::ScanImageEvent*>(e);
  1209. pTask->SetContext(pEvt->m_ctx);
  1210. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  1211. e->SetHandled();
  1212. }
  1213. break;
  1214. case USER_EVT_SCANIMAGE_JS_DONE:
  1215. {
  1216. if (e->param1 == 0) {
  1217. if (e->param2 == 1) uRet = 2;
  1218. else uRet = 1;
  1219. }
  1220. e->SetHandled();
  1221. }
  1222. break;
  1223. case USER_EVT_SETPARAM_JS:
  1224. {
  1225. JS::SetParamTask* pTask = new JS::SetParamTask(this);
  1226. JS::SetParamEvent* pEvt = dynamic_cast<JS::SetParamEvent*>(e);
  1227. pTask->SetContext(pEvt->m_ctx);
  1228. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  1229. e->SetHandled();
  1230. }
  1231. break;
  1232. /*JS Component Done*/
  1233. case USER_EVT_STARTPREVIEW:
  1234. {
  1235. StartPreviewTask* pTask = new StartPreviewTask(this);
  1236. StartPreviewEvent* pEvt = dynamic_cast<StartPreviewEvent*>(e);
  1237. pTask->SetContext(pEvt->m_ctx);
  1238. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  1239. e->SetHandled();
  1240. }
  1241. break;
  1242. case USER_EVT_STARTPREVIEW_FINISHED:
  1243. {
  1244. uRet = e->param1;
  1245. e->SetHandled();
  1246. if (uRet == 1 && ++m_nFatalTimes < MAX_ERROR_TIMES) {
  1247. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("hold on, wait next time (%d/%d).", m_nFatalTimes, MAX_ERROR_TIMES);
  1248. uRet = 2;
  1249. } else if (uRet == 0) {
  1250. m_nFatalTimes = 0;
  1251. }
  1252. if (uRet == 2 && IsDevConnected() == 0) {
  1253. PostEventFIFO(new FSMEvent(USER_EVT_DISCONNECT));
  1254. } else if (uRet == 1) {
  1255. m_desiredAction = USER_EVT_STARTPREVIEW;
  1256. }
  1257. }
  1258. break;
  1259. case USER_EVT_SETPROPERTY:
  1260. {
  1261. SetPropertyEvent* pEvt = dynamic_cast<SetPropertyEvent*>(e);
  1262. SetProperty(pEvt->m_ctx);
  1263. e->SetHandled();
  1264. }
  1265. break;
  1266. case USER_EVT_STOPPREVIEW:
  1267. {
  1268. StopPreviewEvent* pEvt = dynamic_cast<StopPreviewEvent*>(e);
  1269. if(!pEvt->m_ctx->Req.bOnlyHide)
  1270. {//业务在s6状态仅能进行彻底取消预览的操作
  1271. StopPreviewTask* pTask = new StopPreviewTask(this);
  1272. pTask->SetContext(pEvt->m_ctx);
  1273. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  1274. e->SetHandled();
  1275. }
  1276. }
  1277. break;
  1278. case USER_EVT_STOPPREVIEW_FINISHED:
  1279. {
  1280. uRet = e->param1;
  1281. if (uRet == 0 && ++m_nFatalTimes < MAX_ERROR_TIMES) {
  1282. uRet = 3;
  1283. } else if (uRet != 0) {
  1284. m_nFatalTimes = 0;
  1285. }
  1286. if (uRet == 3 && IsDevConnected() == 0) {
  1287. PostEventFIFO(new FSMEvent(USER_EVT_DISCONNECT));
  1288. }
  1289. }
  1290. e->SetHandled();
  1291. break;
  1292. case USER_EVT_SETWINPOS:
  1293. {
  1294. SetWinPosEvent* pEvt = dynamic_cast<SetWinPosEvent*>(e);
  1295. if(pEvt->m_ctx->Req.type == 2)
  1296. {//在s6状态,不允许进行显示和隐藏操作,业务必须通过XXXPreview来进行显示隐藏操作
  1297. SetWinPosTask* pTask = new SetWinPosTask(this);
  1298. pTask->SetContext(pEvt->m_ctx);
  1299. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  1300. e->SetHandled();
  1301. }
  1302. }
  1303. break;
  1304. case USER_EVT_DISCONNECT:
  1305. {
  1306. //jump auto.
  1307. }
  1308. e->SetHandled();
  1309. break;
  1310. case USER_EVT_GETSTATUS:
  1311. {
  1312. GetDevStatusTask* pTask = new GetDevStatusTask(this);
  1313. GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
  1314. pTask->SetContext(pEvt->m_ctx);
  1315. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  1316. }
  1317. e->SetHandled();
  1318. break;
  1319. case USER_EVT_GETINFO:
  1320. {
  1321. GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
  1322. GetDevInfoTask* pTask = new GetDevInfoTask(this);
  1323. pTask->SetContext(pEvt->m_ctx);
  1324. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  1325. }
  1326. e->SetHandled();
  1327. break;
  1328. }
  1329. return uRet;
  1330. }
  1331. void CHSPScannerFSM::s7_Exit_on_entry()
  1332. {
  1333. LOG_FUNCTION();
  1334. FSMEvent* pEvt = new FSMEvent(USER_EVT_EXIT_FINISHED);
  1335. if (ISSUCCEEDED(OnDevExit())) {
  1336. pEvt->param1 = 0;
  1337. } else {
  1338. pEvt->param1 = 1;
  1339. }
  1340. PostEventFIFO(pEvt);
  1341. }
  1342. void CHSPScannerFSM::s7_Exit_on_exit()
  1343. {
  1344. if(m_hDevHelper && m_bOpened)
  1345. {
  1346. HspsDevStatus status = { 0 };
  1347. GetDevStatusFromAdapter(status); /** a test? [Gifur@20241113]*/
  1348. }
  1349. }
  1350. //TODO: [Gifur@20241114]
  1351. unsigned int CHSPScannerFSM::s7_Exit_on_event(FSMEvent* e)
  1352. {
  1353. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s7_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
  1354. unsigned int uRet = 0;
  1355. switch(e->iEvt)
  1356. {
  1357. case USER_EVT_EXIT_FINISHED:
  1358. {
  1359. uRet = e->param1;
  1360. if (uRet == 1) {
  1361. m_desiredAction = USER_EVT_EXIT;
  1362. }
  1363. }
  1364. e->SetHandled();
  1365. break;
  1366. case USER_EVT_GETSTATUS:
  1367. {
  1368. GetDevStatusTask* pTask = new GetDevStatusTask(this);
  1369. GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
  1370. pTask->SetContext(pEvt->m_ctx);
  1371. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  1372. }
  1373. e->SetHandled();
  1374. break;
  1375. case USER_EVT_GETINFO:
  1376. {
  1377. GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
  1378. GetDevInfoTask* pTask = new GetDevInfoTask(this);
  1379. pTask->SetContext(pEvt->m_ctx);
  1380. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  1381. }
  1382. e->SetHandled();
  1383. break;
  1384. }
  1385. return uRet;
  1386. }
  1387. void CHSPScannerFSM::s8_NotConfig_on_entry()
  1388. {
  1389. SetDevState(DEVICE_STATUS_NORMAL); //避免握手重启
  1390. SetLastUserCode(HSPScanner_UserErrorCode_DLLNAME_NOCFG);
  1391. }
  1392. void CHSPScannerFSM::s8_NotConfig_on_exit()
  1393. {
  1394. }
  1395. unsigned int CHSPScannerFSM::s8_NotConfig_on_event(FSMEvent* e)
  1396. {
  1397. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s8_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
  1398. unsigned int uRet = 0;
  1399. switch (e->iEvt) {
  1400. /** JS Component [Gifur@20241112]*/
  1401. case USER_EVT_STARTPREVIEW_JS:
  1402. {
  1403. JS::StartPreviewEvent* pEvt = dynamic_cast<JS::StartPreviewEvent*>(e);
  1404. pEvt->SetHandled();
  1405. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_StartPreviewJS).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG meets USER_EVT_STARTPREVIEW_JS");
  1406. pEvt->m_ctx->Answer(Error_NotConfig, GetLastUserCode());
  1407. }
  1408. break;
  1409. case USER_EVT_CANCELPREVIEW_JS:
  1410. {
  1411. JS::CancelPreviewEvent* pEvt = dynamic_cast<JS::CancelPreviewEvent*>(e);
  1412. pEvt->SetHandled();
  1413. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_CancelPreviewJS).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG meets USER_EVT_CANCELPREVIEW_JS");
  1414. pEvt->m_ctx->Answer(Error_NotConfig, GetLastUserCode());
  1415. }
  1416. break;
  1417. case USER_EVT_SCANIMAGE_JS:
  1418. {
  1419. JS::ScanImageEvent* pEvt = dynamic_cast<JS::ScanImageEvent*>(e);
  1420. pEvt->SetHandled();
  1421. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImageJS).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG meets USER_EVT_SCANIMAGE_JS");
  1422. pEvt->m_ctx->Answer(Error_NotConfig, GetLastUserCode());
  1423. }
  1424. break;
  1425. case USER_EVT_SETPARAM_JS:
  1426. {
  1427. JS::SetParamEvent* pEvt = dynamic_cast<JS::SetParamEvent*>(e);
  1428. pEvt->SetHandled();
  1429. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_SetParamJS).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG meets USER_EVT_SETPARAM_JS");
  1430. pEvt->m_ctx->Answer(Error_NotConfig, GetLastUserCode());
  1431. }
  1432. break;
  1433. /** JS Compoent Done [Gifur@20241112]*/
  1434. case USER_EVT_STARTPREVIEW:
  1435. {
  1436. StartPreviewEvent* pEvt = dynamic_cast<StartPreviewEvent*>(e);
  1437. pEvt->SetHandled();
  1438. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_StartPreview).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG meets USER_EVT_STARTPREVIEW");
  1439. pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
  1440. }
  1441. break;
  1442. case USER_EVT_STOPPREVIEW:
  1443. {
  1444. StopPreviewEvent* pEvt = dynamic_cast<StopPreviewEvent*>(e);
  1445. pEvt->SetHandled();
  1446. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_CancelPreview).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG meets USER_EVT_STOPPREVIEW");
  1447. pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
  1448. }
  1449. break;
  1450. case USER_EVT_SCANIMAGE:
  1451. {
  1452. ScanImageEvent* pEvt = dynamic_cast<ScanImageEvent*>(e);
  1453. pEvt->SetHandled();
  1454. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImage).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG meets USER_EVT_SCANIMAGE");
  1455. pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
  1456. }
  1457. break;
  1458. case USER_EVT_SCANIMAGE_EX:
  1459. {
  1460. ScanImageExEvent* pEvt = dynamic_cast<ScanImageExEvent*>(e);
  1461. pEvt->SetHandled();
  1462. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImageEx).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG meets USER_EVT_SCANIMAGE_EX");
  1463. pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
  1464. }
  1465. break;
  1466. case USER_EVT_SHOWPROPERTY:
  1467. {
  1468. ShowPropertyEvent* pEvt = dynamic_cast<ShowPropertyEvent*>(e);
  1469. pEvt->SetHandled();
  1470. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ShowProperty).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG meets USER_EVT_SHOWPROPERTY");
  1471. pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
  1472. }
  1473. break;
  1474. case USER_EVT_SETPROPERTY:
  1475. {
  1476. SetPropertyEvent* pEvt = dynamic_cast<SetPropertyEvent*>(e);
  1477. pEvt->SetHandled();
  1478. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_SetProperty).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG meets USER_EVT_SETPROPERTY");
  1479. pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
  1480. }
  1481. break;
  1482. case USER_EVT_SETWINPOS:
  1483. {
  1484. SetWinPosEvent* pEvt = dynamic_cast<SetWinPosEvent*>(e);
  1485. pEvt->SetHandled();
  1486. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_SetWinPos).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG meets USER_EVT_SETWINPOS");
  1487. pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
  1488. }
  1489. break;
  1490. case USER_EVT_GETSTATUS:
  1491. {
  1492. GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
  1493. pEvt->SetHandled();
  1494. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevStatus).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG meets USER_EVT_SETWINPOS");
  1495. pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
  1496. }
  1497. break;
  1498. case USER_EVT_GETINFO:
  1499. {
  1500. GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
  1501. GetDevInfoTask* pTask = new GetDevInfoTask(this);
  1502. pTask->SetContext(pEvt->m_ctx);
  1503. GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
  1504. }
  1505. e->SetHandled();
  1506. break;
  1507. default:
  1508. break;
  1509. }
  1510. return uRet;
  1511. }
  1512. int CHSPScannerFSM::StartPreview(SpReqAnsContext<HSPScannerService_StartPreview_Req,
  1513. HSPScannerService_StartPreview_Ans>::Pointer ctx)
  1514. {
  1515. bool nRes = 0;
  1516. ErrorCodeEnum erroCode = Error_Unexpect;
  1517. SetLastUserCode();
  1518. if (ctx->Req.colorType || ctx->Req.scanType || ctx->Req.rotateType) {
  1519. const int retCode = SetPreviewParam(ctx->Req.colorType, ctx->Req.rotateType, ctx->Req.scanType);
  1520. if (retCode != 0)
  1521. {
  1522. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("SetPreviewParam return some wrong:0x%X", retCode);
  1523. erroCode = Error_DevCommFailed;
  1524. }
  1525. else {
  1526. erroCode = Error_Succeed;
  1527. }
  1528. }
  1529. HspsDevStatus status = { 0 };
  1530. erroCode = GetDevStatusFromAdapter(status);
  1531. if (ISSUCCEEDED(erroCode) && status.inPreview) {// 用于s6状态 [Josephus in 9:33:48 2016/11/22]
  1532. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  1533. erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_SHOW);
  1534. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  1535. if (ISSUCCEEDED(erroCode)) {
  1536. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_StartPreview).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)("HSPS_VIEW_SHOW");
  1537. } else {
  1538. //RTA2N0R
  1539. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_StartPreview, CombineJsonContext("HSPS_VIEW_SHOW"));
  1540. const DWORD dwCode = GetAlarmDEC();
  1541. CSimpleStringA tmpRTA(true), tmpDesc(true);
  1542. if (GetEntityBase()->GetFunction()->GetVTMErrMsg(dwCode, tmpDesc, tmpRTA) == Error_Succeed)
  1543. DbgToBeidou(ctx->link, "StartPreview::SetParam").setReturnCode(tmpRTA)();
  1544. SetLastUserCode(dwCode);
  1545. }
  1546. } else if (ISSUCCEEDED(erroCode)) {
  1547. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("Start to SetPreview(1)...");
  1548. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  1549. erroCode = m_hDevHelper->SetPreview(1);
  1550. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  1551. if (FAILURED(erroCode)) {
  1552. //RTA2N03
  1553. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetPreview_Open, "DevAdapter::SetPreview", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_StartPreview, CombineJsonContext("StartPreview::SetPreview(1)"));
  1554. SetLastUserCode(GetAlarmDEC());
  1555. } else {
  1556. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_StartPreview).setAPI("DevAdapter::SetPreview").setCostTime(ullEnd - ullStart)("StartPreview::SetPreview(1)");
  1557. }
  1558. }
  1559. if (FAILURED(erroCode)) {
  1560. nRes = 1;
  1561. } else {
  1562. LogEvent(Severity_Middle, LOG_EVT_HSPS_LIGHT_ON, "HSPScanner warning on.");
  1563. }
  1564. ctx->Answer(TransECWithRepeat(erroCode), GetLastUserCode());
  1565. return nRes;
  1566. }
  1567. int CHSPScannerFSM::StopPreview(SpReqAnsContext<HSPScannerService_CancelPreview_Req,
  1568. HSPScannerService_CancelPreview_Ans>::Pointer ctx)
  1569. {
  1570. ErrorCodeEnum erroCode = Error_Unexpect;
  1571. int nRes = 0;
  1572. if (ctx->Req.bOnlyHide) {
  1573. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  1574. erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
  1575. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  1576. if (ISSUCCEEDED(erroCode)) {
  1577. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_CancelPreview).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)("HSPS_VIEW_HIDE");
  1578. nRes = 1;
  1579. } else {
  1580. //RTA2N0Q
  1581. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_CancelPreview, CombineJsonContext("HSPS_VIEW_HIDE"));
  1582. SetLastUserCode(GetAlarmDEC());
  1583. nRes = 4;
  1584. }
  1585. }
  1586. else
  1587. {
  1588. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_USER)("Start to SetPreview(0).");
  1589. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  1590. erroCode = m_hDevHelper->SetPreview(0);
  1591. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  1592. if (ISSUCCEEDED(erroCode)) {
  1593. nRes = 2;
  1594. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_CancelPreview).setAPI("DevAdapter::CancelPreview").setCostTime(ullEnd - ullStart)("SetPreview(0) succ");
  1595. LogWarn(Severity_Low, Error_Debug, LOG_EVT_HSPSCANNER_SetPreview_Close, "cancelPreview succ.");
  1596. } else {
  1597. //RTA2N04
  1598. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetPreview_Close, "DevAdapter::CancelPreview", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_CancelPreview, CombineJsonContext("SetPreview(0)"));
  1599. const DWORD dwCode = GetAlarmDEC();
  1600. CSimpleStringA tmpRTA(true), tmpDesc(true);
  1601. if (GetEntityBase()->GetFunction()->GetVTMErrMsg(dwCode, tmpDesc, tmpRTA) == Error_Succeed)
  1602. DbgToBeidou(ctx->link, __FUNCTION__).setReturnCode(tmpRTA)();
  1603. SetLastUserCode(dwCode);
  1604. }
  1605. }
  1606. if (ISSUCCEEDED(erroCode)) {
  1607. LogEvent(Severity_Middle, LOG_EVT_HSPS_LIGHT_OFF, "HSPScanner warning off.");
  1608. }
  1609. ctx->Answer(TransECWithRepeat(erroCode), GetLastUserCode());
  1610. return nRes;
  1611. }
  1612. bool CHSPScannerFSM::ResizeImage(const CSimpleStringA& fileName, int kbSize)
  1613. {
  1614. double rate; //limit rate
  1615. int width;
  1616. int height;
  1617. bool success = TRUE;
  1618. const int imageSize = kbSize * 1024;
  1619. FILE* fHandle = fopen(fileName.GetData(), "rb");
  1620. if (!fHandle) {
  1621. LogWarn(Severity_Middle, Error_Unexpect, LOG_WARN_HSPS_RESIZE_IMAGE_FILE_FAILED
  1622. , CSimpleStringA::Format("fopen image %s for resize failed: %d", fileName.GetData(), errno));
  1623. return FALSE;
  1624. }
  1625. fseek(fHandle, 0, SEEK_END);
  1626. long fileSize = ftell(fHandle);
  1627. fclose(fHandle);
  1628. if (fileSize <= (imageSize)) {
  1629. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("File(%s)(%u<=%u) no need resize.", (LPCTSTR)fileName, fileSize, imageSize);
  1630. return TRUE;
  1631. }
  1632. CSimpleStringA backUpFile, backUpPath;
  1633. m_pEntity->GetFunction()->GetPath("Temp", backUpPath);
  1634. backUpFile = backUpPath + SPLIT_SLASH_STR + "backupHSPSCannerImage";
  1635. DeleteFileIfExisted(backUpFile);
  1636. #ifndef _WIN32
  1637. fileutil_copy_file((LPCTSTR)backUpFile, (LPCTSTR)fileName);
  1638. #else
  1639. CopyFileA(fileName, backUpFile, FALSE);
  1640. #endif //NOT _WIN32
  1641. while (fileSize > imageSize)
  1642. {
  1643. rate = (double)fileSize / imageSize;
  1644. rate = 1.0 / sqrt(rate); //width and height limit rate
  1645. cv::Mat img = cv::imread(fileName.GetData());
  1646. if (!img.data) {
  1647. LogWarn(Severity_Middle, Error_Unexpect, LOG_WARN_HSPS_OPENCV_READ_FAILED, "Opencv READ failed!");
  1648. success = FALSE;
  1649. break;
  1650. }
  1651. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_USER)("to resize %lf rate...", rate);
  1652. width = img.cols;
  1653. height = img.rows;
  1654. cv::resize(img, img, cv::Size(width * rate, height * rate));
  1655. const bool openwrite = cv::imwrite(fileName.GetData(), img);
  1656. if (!openwrite) {
  1657. LogWarn(Severity_Middle, Error_Unexpect, LOG_WARN_HSPS_OPENCV_WRITE_FAILED, "Opencv WRITE failed!");
  1658. success = FALSE;
  1659. break;
  1660. }
  1661. fHandle = fopen(fileName.GetData(), "rb");
  1662. fseek(fHandle, 0, SEEK_END);
  1663. fileSize = ftell(fHandle);
  1664. fclose(fHandle);
  1665. Sleep(2);
  1666. }
  1667. if (!success) {
  1668. #ifndef _WIN32
  1669. ///*TODO(80374374@3/3/2023): */
  1670. fileutil_copy_file((LPCTSTR)fileName, (LPCTSTR)backUpFile); //recover original img
  1671. #endif //NOT _WIN32
  1672. CopyFileA(backUpFile, fileName, FALSE);
  1673. DeleteFileIfExisted(backUpFile);
  1674. return FALSE;
  1675. }
  1676. fileSize = fileSize / 1024;
  1677. DeleteFileIfExisted(backUpFile);
  1678. LogWarn(Severity_Low, Error_Unexpect, LOG_WARN_HSPS_RESIZE_FUNCTION_SUCCEED,
  1679. CSimpleStringA::Format("HSPScanner resize image succeed, SIZE : %d KB.", fileSize));
  1680. return TRUE;
  1681. }
  1682. int CHSPScannerFSM::ScanImage(SpReqAnsContext<HSPScannerService_ScanImage_Req,
  1683. HSPScannerService_ScanImage_Ans>::Pointer ctx)
  1684. {
  1685. int nRes = 0;
  1686. ErrorCodeEnum erroCode = Error_Unexpect;
  1687. CSimpleStringA csImageFile;
  1688. GetCurImageName(csImageFile);
  1689. BOOL bRet = DelAndGetNewFileName(csImageFile);
  1690. if (!bRet) {
  1691. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImage).setResultCode(MapCode2RTAString(HSPScanner_UserErrorCode_CLEAR_RESOURCE_FAILED))("Cleare previous image failed before ScanImage");
  1692. ctx->Answer(TransECWithRepeat(Error_Resource), HSPScanner_UserErrorCode_CLEAR_RESOURCE_FAILED);
  1693. return 1;
  1694. }
  1695. ///*TODO: (80374374@2/20/2024)*/
  1696. LogWarn(Severity_Low, Error_Debug, LOG_DEBUG_HSPS_CRITICAL_OPERATION_SCANIMAGE_START, "to ScanImage...");
  1697. ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  1698. erroCode = m_hDevHelper->ScanImage((LPCTSTR)csImageFile);
  1699. ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  1700. if (ISSUCCEEDED(erroCode)) {
  1701. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::ScanImage").setCostTime(ullEnd - ullStart)("DevAdapter::ScanImage succ");
  1702. ///*TODO: (80374374@2/20/2024)*/
  1703. LogWarn(Severity_Low, Error_Debug, LOG_DEBUG_HSPS_CRITICAL_OPERATION_SCANIMAGE_SUCC, "ScanImage succ");
  1704. if (!ResizeImage(csImageFile, m_dwMaxImageSize)) {
  1705. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setResultCode(MapCode2RTAString(LOG_WARN_HSPS_RESIZE_IMAGE_FILE_FAILED)).setAPI(__FUNCTION__)("HSPScanner resize image failed");
  1706. }
  1707. ctx->Ans.filePath = csImageFile;
  1708. CBlob& cbData = ctx->Ans.imageData;
  1709. FILE* fHandle = fopen(csImageFile, "rb");
  1710. if (fHandle) {
  1711. fseek(fHandle, 0, SEEK_END);
  1712. long fileSize = ftell(fHandle);
  1713. if (fileSize <= 0) {
  1714. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImage).setResultCode("RTA2N0S")("ftell(%s) error after invoking scanimage: %ld.", (LPCTSTR)csImageFile, fileSize);
  1715. erroCode = Error_NotExist;
  1716. fclose(fHandle);
  1717. nRes = 4;
  1718. } else {
  1719. cbData.Alloc(fileSize);
  1720. fseek(fHandle, 0, SEEK_SET);
  1721. fread(cbData.m_pData, 1, fileSize, fHandle);
  1722. fclose(fHandle);
  1723. }
  1724. } else {
  1725. erroCode = Error_Resource;
  1726. const int lasterr = errno;
  1727. LogWarn(Severity_Middle, Error_Resource, HSPScanner_UserErrorCode_READ_IMAGE_FILE_FAILED, CSimpleStringA::Format("fopen(%s) failed after invoking scanimage: %d", (LPCTSTR)csImageFile, lasterr));
  1728. SetLastUserCode(HSPScanner_UserErrorCode_READ_IMAGE_FILE_FAILED);
  1729. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImage).setResultCode("RTA2N0S")("fopen(%s) failed after invoking scanimage: %d", (LPCTSTR)csImageFile, lasterr);
  1730. nRes = 4;
  1731. }
  1732. if (ISSUCCEEDED(erroCode)) {
  1733. // Additional ChangeTo Hide --Josephus at 11:32:29 2016/11/22
  1734. if (true/*TODO: */) {
  1735. ullStart = SP::Module::Comm::RVCGetTickCount();
  1736. ErrorCodeEnum eHide = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
  1737. ullEnd = SP::Module::Comm::RVCGetTickCount();
  1738. if (ISSUCCEEDED(eHide)) {
  1739. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)("Hide Preview Dialog");
  1740. nRes = 6;
  1741. } else {
  1742. //RTA2N0Q
  1743. SetErrorAndLog(eHide, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_ScanImage, CombineJsonContext("HSPS_VIEW_HIDE"));
  1744. }
  1745. }
  1746. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImage).setAPI(__FUNCTION__)("ScanImage succ");
  1747. }
  1748. ctx->Answer(TransECWithRepeat(erroCode), GetLastUserCode());
  1749. } else {
  1750. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_ScanImage, "DevAdapter::ScanImage", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_ScanImage);
  1751. SetLastUserCode(GetAlarmDEC());
  1752. ctx->Answer(TransECWithRepeat(erroCode), GetLastUserCode());
  1753. nRes = 2;
  1754. }
  1755. return nRes;
  1756. }
  1757. int CHSPScannerFSM::ScanImageEx(SpReqAnsContext<HSPScannerService_ScanImageEx_Req,
  1758. HSPScannerService_ScanImageEx_Ans>::Pointer ctx)
  1759. {
  1760. int nRes = 0;
  1761. ErrorCodeEnum erroCode = Error_Unexpect;
  1762. CSimpleStringA csImageFile;
  1763. GetCurImageName(csImageFile, true);
  1764. BOOL bRet = DelAndGetNewFileName(csImageFile);
  1765. if (!bRet) {
  1766. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setResultCode(MapCode2RTAString(HSPScanner_UserErrorCode_CLEAR_RESOURCE_FAILED))("Cleare previous image failed before ScanImageEx");
  1767. ctx->Answer(TransECWithRepeat(Error_Resource), HSPScanner_UserErrorCode_CLEAR_RESOURCE_FAILED);
  1768. return 1;
  1769. }
  1770. int len = 0;
  1771. BYTE* pBtImage = NULL;
  1772. LogWarn(Severity_Low, Error_Debug, LOG_DEBUG_HSPS_CRITICAL_OPERATION_SCANIMAGEEX_START, "to ScanImageEx...");
  1773. ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  1774. erroCode = m_hDevHelper->ScanImageEx(pBtImage, len, (LPCTSTR)csImageFile);
  1775. ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  1776. if(erroCode == Error_TooSmallBuffer) {
  1777. if (pBtImage) {
  1778. delete pBtImage;
  1779. pBtImage = NULL;
  1780. }
  1781. len += MAX_IMAGEDATA_SUFFIX;
  1782. pBtImage = new BYTE[len+1];
  1783. if (pBtImage == NULL) {
  1784. DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setLogCode(HSPScannerService_LogCode_ScanImageEx).setResultCode("RTA2N0T")("new buffer[%d] failed %d.", len + 1, GetLastError());
  1785. ctx->Answer(Error_Resource);
  1786. return 3;
  1787. }
  1788. memset((void*)pBtImage, 0, len+1);
  1789. ullStart = SP::Module::Comm::RVCGetTickCount();
  1790. erroCode = m_hDevHelper->ScanImageEx(pBtImage, len, (LPCTSTR)csImageFile);
  1791. ullEnd = SP::Module::Comm::RVCGetTickCount();
  1792. if (erroCode == Error_Succeed) {
  1793. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::ScanImageEx").setCostTime(ullEnd - ullStart)("ScanImageEx suc %d, %d.", len, strlen((const char*)pBtImage));
  1794. }
  1795. }
  1796. if (ISSUCCEEDED(erroCode)) {
  1797. LogWarn(Severity_Low, Error_Debug, LOG_DEBUG_HSPS_CRITICAL_OPERATION_SCANIMAGEEX_SUCC, CSimpleStringA::Format("ScanImageEx suc %d, %d.", len, strlen((const char*)pBtImage)));
  1798. if (ResizeImage(csImageFile, m_dwMaxImageSize)) {
  1799. FILE* fHandle = fopen(csImageFile.GetData(), "rb");
  1800. fseek(fHandle, 0, SEEK_END);
  1801. len = ftell(fHandle);
  1802. fseek(fHandle, 0, SEEK_SET);
  1803. if (pBtImage) delete[] pBtImage;
  1804. pBtImage = new BYTE[len];
  1805. fread(pBtImage, 1, len, fHandle);
  1806. fclose(fHandle);
  1807. }
  1808. else {
  1809. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setResultCode(MapCode2RTAString(LOG_WARN_HSPS_RESIZE_IMAGE_FILE_FAILED)).setAPI(__FUNCTION__)("HSPScanner resize image failed");
  1810. }
  1811. ctx->Ans.filePath = csImageFile;
  1812. CBlob& cbData = ctx->Ans.imageData;
  1813. cbData.Alloc((len + 1) * sizeof(BYTE));
  1814. memcpy_s(cbData.m_pData, cbData.m_iLength, pBtImage, len);
  1815. cbData.Resize(len);
  1816. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("ScanImageEx ctx: %s, %d.", (LPCTSTR)ctx->Ans.filePath, ctx->Ans.imageData.m_iLength);
  1817. // Additional ChangeTo Hide --Josephus at 11:29:03 2016/11/22
  1818. if (ISSUCCEEDED(erroCode)) {
  1819. ullStart = SP::Module::Comm::RVCGetTickCount();
  1820. ErrorCodeEnum eHide = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
  1821. ullEnd = SP::Module::Comm::RVCGetTickCount();
  1822. if (ISSUCCEEDED(eHide)) {
  1823. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)("Hide Preview Dialog");
  1824. nRes = 6;
  1825. } else {
  1826. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart).setResultCode("RTA2N0Q")("Hide Preview Dialog failed: %s", SpStrError(eHide));
  1827. }
  1828. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI(__FUNCTION__).setLogCode(HSPScannerService_LogCode_ScanImageEx)("ScanImageEx ctx: %s, %d.", (LPCTSTR)ctx->Ans.filePath, ctx->Ans.imageData.m_iLength);
  1829. }
  1830. ctx->Answer(TransECWithRepeat(erroCode));
  1831. } else {
  1832. //RTA2N06
  1833. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_ScanImageEx, "DevAdapter::ScanImageEx", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_ScanImageEx);
  1834. SetLastUserCode(GetAlarmDEC());
  1835. ctx->Answer(TransECWithRepeat(erroCode), GetLastUserCode());
  1836. nRes = 2;
  1837. }
  1838. if (pBtImage) {
  1839. delete pBtImage;
  1840. pBtImage = NULL;
  1841. }
  1842. return nRes;
  1843. }
  1844. int CHSPScannerFSM::ShowProperty(SpReqAnsContext<HSPScannerService_ShowProperty_Req,
  1845. HSPScannerService_ShowProperty_Ans>::Pointer ctx)
  1846. {
  1847. ErrorCodeEnum erroCode = Error_Succeed;
  1848. // Return ahead. [Josephus in 15:24:15 2016/11/21]
  1849. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  1850. ErrorCodeEnum ePos = m_hDevHelper->SetViewPos(730, 100, 540);
  1851. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  1852. if (FAILURED(ePos)) {
  1853. //RTA2N07
  1854. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetViewPos, "DevAdapter::SetViewPos", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_ShowProperty);
  1855. } else {
  1856. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ShowProperty).setAPI("DevAdapter::SetViewPos").setCostTime(ullEnd - ullStart)();
  1857. }
  1858. ctx->Answer(TransECWithRepeat(erroCode));
  1859. DWORD dwStart = GetTickCount();
  1860. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Start to show Property dialog...");
  1861. erroCode = m_hDevHelper->SetProperty();
  1862. DWORD dwEnd = GetTickCount();
  1863. if (FAILURED(erroCode)) {
  1864. //RTA2N0U
  1865. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetProperty, "DevAdapter::SetProperty", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_ShowProperty);
  1866. } else {
  1867. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetProperty").setCostTime(dwEnd - dwStart)();
  1868. erroCode = m_hDevHelper->SetViewPos(m_nRecX, m_nRecY, m_nRecW);
  1869. }
  1870. return 0;
  1871. }
  1872. int CHSPScannerFSM::SetProperty(SpReqAnsContext<HSPScannerService_SetProperty_Req,
  1873. HSPScannerService_SetProperty_Ans>::Pointer ctx)
  1874. {
  1875. int nRes = 0;
  1876. ErrorCodeEnum erroCode = Error_Succeed;
  1877. int retCode = SetPreviewParam(ctx->Req.colorType, ctx->Req.rotateType, ctx->Req.scanType);
  1878. if (retCode != 0) {
  1879. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_SetProperty).setResultCode(MapCode2RTAString(GetLastUserCode()))("SetParam failed retCode: 0x%X", retCode);
  1880. } else {
  1881. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_SetProperty)("Set Property succ.");
  1882. }
  1883. ctx->Ans.retCode = retCode;
  1884. ctx->Answer(Error_Succeed);
  1885. return nRes;
  1886. }
  1887. int CHSPScannerFSM::SetWinPos(SpReqAnsContext<HSPScannerService_SetWinPos_Req,
  1888. HSPScannerService_SetWinPos_Ans>::Pointer ctx)
  1889. {
  1890. int nRes = 0;
  1891. ErrorCodeEnum erroCode = Error_Unexpect;
  1892. ParamTypeValue value = HSPS_VIEW_SHOW;
  1893. bool bSetCustom = false;
  1894. switch (ctx->Req.type) {
  1895. case 0: value = HSPS_VIEW_HIDE; break;
  1896. case 1: value = HSPS_VIEW_SHOW; break;
  1897. case 2: bSetCustom = true; break;
  1898. default:
  1899. {
  1900. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_SetWinPos).setResultCode(MapCode2RTAString(HSPScanner_UserErrorCode_NOT_SUPPORT))("invalid param for SetWinPos operation type(%d).", ctx->Req.type);
  1901. ctx->Answer(Error_Param, HSPScanner_UserErrorCode_NOT_SUPPORT);
  1902. return nRes = 3;
  1903. }
  1904. break;
  1905. }
  1906. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_USER)("SetWinPos: %s(%d).", ParamValToString(value), value);
  1907. if (bSetCustom) {
  1908. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_USER)("Start to SetViewPos x(%d), y(%d), w(%d), reserved(%d).",
  1909. ctx->Req.pointX, ctx->Req.pointY, ctx->Req.nWidth, ctx->Req.reserved4);
  1910. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  1911. erroCode = m_hDevHelper->SetViewPos(ctx->Req.pointX, ctx->Req.pointY, ctx->Req.nWidth);
  1912. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  1913. if (ISSUCCEEDED(erroCode)) {
  1914. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetViewPos").setCostTime(ullEnd - ullStart)("x: %d, y: %d, w: %d", ctx->Req.pointX, ctx->Req.pointY, ctx->Req.nWidth);
  1915. m_nRecX = ctx->Req.pointX;
  1916. m_nRecY = ctx->Req.pointY;
  1917. m_nRecW = ctx->Req.nWidth;
  1918. } else {
  1919. //RTA2N07
  1920. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetViewPos, "DevAdapter::SetViewPos", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_SetWinPos);
  1921. SetLastUserCode(GetAlarmDEC());
  1922. nRes = 2;
  1923. }
  1924. } else {
  1925. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  1926. erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, value);
  1927. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  1928. if (ISSUCCEEDED(erroCode)) {
  1929. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)("%d", value);
  1930. } else {
  1931. //RTA2N02
  1932. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_SetWinPos);
  1933. SetLastUserCode(GetAlarmDEC());
  1934. nRes = 1;
  1935. }
  1936. }
  1937. if (ISSUCCEEDED(erroCode)) {
  1938. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_SetWinPos)("SetWinPos succ.");
  1939. }
  1940. else {
  1941. CSimpleStringA tmpRTA(true), tmpDesc(true);
  1942. if (GetEntityBase()->GetFunction()->GetVTMErrMsg(GetLastUserCode(), tmpDesc, tmpRTA) == Error_Succeed)
  1943. DbgToBeidou(ctx->link, "SetWinPos").setReturnCode(tmpRTA)();
  1944. }
  1945. ctx->Answer(TransECWithRepeat(erroCode), GetLastUserCode());
  1946. return nRes;
  1947. }
  1948. int CHSPScannerFSM::GetDevStatus(SpReqAnsContext<HSPScannerService_GetDevStatus_Req,
  1949. HSPScannerService_GetDevStatus_Ans>::Pointer ctx)
  1950. {
  1951. int nRes = 0;
  1952. HspsDevStatus status = { 0 };
  1953. ErrorCodeEnum erroCode = GetDevStatusFromAdapter(status, true);
  1954. if (ISSUCCEEDED(erroCode)) {
  1955. ctx->Ans.connected = status.isConnected;
  1956. ctx->Ans.previewing = status.inPreview;
  1957. ctx->Ans.showing = status.inShow;
  1958. }
  1959. else {
  1960. nRes = 1;
  1961. }
  1962. ctx->Answer(TransECWithRepeat(erroCode), GetLastUserCode());
  1963. return nRes;
  1964. }
  1965. ErrorCodeEnum CHSPScannerFSM::GetDevStatusFromAdapter(HspsDevStatus& status, bool fromBusiness)
  1966. {
  1967. ErrorCodeEnum erroCode(Error_NotInit);
  1968. if (m_hDevHelper) {
  1969. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  1970. ErrorCodeEnum erroCode = m_hDevHelper->GetDevStatus(status);
  1971. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  1972. if (ISSUCCEEDED(erroCode)) {
  1973. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevStatus).setAPI("DevAdapter::GetDevStatus").setCostTime(ullEnd - ullStart)("{\"connected\": %d, \"previewing\": %d, \"showing\": %d}", status.isConnected, status.inPreview, status.inShow);
  1974. }
  1975. else {
  1976. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_GetDevStatus, "DevAdapter::GetDevStatus", __FUNCTION__, fromBusiness ? IsInBusiness() : false, ullEnd - ullStart, fromBusiness ? HSPScannerService_LogCode_GetDevStatus : "");
  1977. if (fromBusiness) SetLastUserCode(GetAlarmDEC());
  1978. }
  1979. }
  1980. return erroCode;
  1981. }
  1982. int CHSPScannerFSM::GetDevInfo(SpReqAnsContext<HSPScannerService_GetDevInfo_Req,
  1983. HSPScannerService_GetDevInfo_Ans>::Pointer ctx)
  1984. {
  1985. int nRes = 0;
  1986. if (m_bOpening) {
  1987. //如果打开还没有结束,GetDevInfo返回Error_NotInit
  1988. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevInfo).setResultCode(MapCode2RTAString(LOG_WARN_HSPS_OPENING_NOW)).setAPI(__FUNCTION__)("device is opening");
  1989. ctx->Answer(Error_NotInit, LOG_WARN_HSPS_OPENING_NOW);
  1990. nRes = 1;
  1991. } else if (!m_bOpened) {
  1992. //如果打开失败,GetDevInfo应该返回Error_DevNotAvailable
  1993. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevInfo).setAPI(__FUNCTION__).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
  1994. ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
  1995. nRes = 1;
  1996. } else {
  1997. //打开成功。GetDevInfo返回Error_Succeed,state放获取模块信息(GetDevCategory这个适配器接口调用)的返回值
  1998. DevCategoryInfo info = { 0 };
  1999. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  2000. ErrorCodeEnum erroCode = m_hDevHelper->GetDevCategory(info);
  2001. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  2002. ctx->Ans.state = (int)(erroCode);
  2003. if (ISSUCCEEDED(erroCode)) {
  2004. ctx->Ans.model = info.szModel;
  2005. ctx->Ans.type = info.szType;
  2006. ctx->Ans.version = CSimpleStringA::Format("%d.%d.%d.%d",
  2007. info.version.wMajor, info.version.wMinor, info.version.wRevision, info.version.wBuild);
  2008. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevInfo).setAPI("DevAdapter::GetDevCategory").setCostTime(ullEnd - ullStart)("model: %s, state:%d, type:%s, version:%s"
  2009. , ctx->Ans.model.GetData(), ctx->Ans.state, ctx->Ans.type.GetData(), ctx->Ans.version.GetData());
  2010. }
  2011. else {
  2012. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_GetDevCategory, "DevAdapter::GetDevCategory", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_GetDevInfo);
  2013. SetLastUserCode(GetAlarmDEC());
  2014. nRes = 1;
  2015. }
  2016. ctx->Answer(Error_Succeed);
  2017. }
  2018. return nRes;
  2019. }
  2020. BOOL CHSPScannerFSM::GetCurImageName(CSimpleStringA& csImagName, bool bExt /*= false*/)
  2021. {
  2022. if (bExt) {
  2023. csImagName = "MaterialImageExt.jpg";
  2024. } else {
  2025. csImagName = "MaterialImage.jpg";
  2026. }
  2027. return TRUE;
  2028. }
  2029. BOOL CHSPScannerFSM::DelAndGetNewFileName(CSimpleStringA& csfileName, bool bInBusiness)
  2030. {
  2031. char fileName[MAX_PATH_SIZE] = {0};
  2032. memset(fileName, 0, sizeof(char)*MAX_PATH_SIZE);
  2033. strcpy_s(fileName, MAX_PATH_SIZE, (LPCTSTR)csfileName);
  2034. if (strlen(fileName) == 0 || strchr(fileName, (int)'*') != NULL) {
  2035. DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("Error input param");
  2036. return FALSE;
  2037. }
  2038. CSimpleStringA strPath, strAimPath;
  2039. m_pEntity->GetFunction()->GetPath("Dep", strPath);
  2040. strAimPath = strPath + SPLIT_SLASH_STR + fileName;
  2041. UpdateAndWarnFileFindInDepBak(strAimPath, fileName, HSPScanner_UserErrorCode_FindFile_in_DepBak);
  2042. #if 0
  2043. ///*TODO(80374374@10/11/2022): 这段代码上线一段时间后要去除,因为从这个版本开始这个文件就不生成在这个目录了 */
  2044. if (ExistsFileA(strAimPath)) {
  2045. if (DeleteFileA((LPCTSTR)strAimPath) != 0) {
  2046. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("DeleteFile(%s) suc.", (LPCTSTR)strAimPath);
  2047. } else {
  2048. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("DeleteFile(%s) failed LastError(%d).", (LPCTSTR)strAimPath, GetLastError());
  2049. }
  2050. }
  2051. strPath.Clear();
  2052. GetEntityBase()->GetFunction()->GetPath("Temp", strPath);
  2053. strAimPath = strPath + SPLIT_SLASH_STR + fileName;
  2054. #endif
  2055. // Add [Josephus in 17:04:27 2016/10/25]
  2056. csfileName = strAimPath;
  2057. if (ExistsFileA(csfileName)) {
  2058. if (RemoveFileA((LPCTSTR)strAimPath) != 0) {
  2059. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("DeleteFile(%s) suc.", (LPCTSTR)strAimPath);
  2060. return TRUE;
  2061. } else {
  2062. if (bInBusiness) {
  2063. DWORD lastErr = GetLastError();
  2064. if (lastErr == 5) {
  2065. Sleep(100);
  2066. if (!ExistsFileA(csfileName) || RemoveFileA((LPCTSTR)strAimPath) != 0) {
  2067. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("DeleteFile(%s) suc.", (LPCTSTR)strAimPath);
  2068. return TRUE;
  2069. }
  2070. lastErr = GetLastError();
  2071. }
  2072. LogError(Severity_Middle, Error_Unexpect, HSPScanner_UserErrorCode_CLEAR_RESOURCE_FAILED, CSimpleStringA::Format(
  2073. "DeleteFile(%s) failed before ScanImage, LastError(%d).", (LPCTSTR)strAimPath, lastErr));
  2074. } else {
  2075. LogWarn(Severity_High, Error_Unexpect, HSPScanner_UserErrorCode_CLEAR_RESOURCE_FAILED, CSimpleStringA::Format(
  2076. "DeleteFile(%s) failed, LastError(%d).", (LPCTSTR)strAimPath, GetLastError()));
  2077. }
  2078. return FALSE;
  2079. }
  2080. } else {
  2081. return TRUE;
  2082. }
  2083. }
  2084. ErrorCodeEnum CHSPScannerFSM::OnDevExit()
  2085. {
  2086. LOG_FUNCTION();
  2087. ErrorCodeEnum erroCode = Error_Succeed;
  2088. if(m_hDevHelper)
  2089. {
  2090. HspsDevStatus status = { 0 };
  2091. erroCode = GetDevStatusFromAdapter(status);
  2092. if (ISSUCCEEDED(erroCode) && status.isConnected)
  2093. {
  2094. if (status.inPreview) {
  2095. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Invoke cancelPreview...");
  2096. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  2097. erroCode = m_hDevHelper->SetPreview(0);
  2098. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  2099. if (ISSUCCEEDED(erroCode)) {
  2100. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setLogCode(__FUNCTION__).setAPI("DevAdapter::CancelPreview").setCostTime(ullEnd - ullStart)();
  2101. LogEvent(Severity_Middle, LOG_EVT_HSPS_LIGHT_OFF, "HSPScanner warning off.");
  2102. ///*TODO: (80374374@2/20/2024)*/
  2103. LogWarn(Severity_Low, Error_Debug, LOG_EVT_HSPSCANNER_SetPreview_Close, "cancelPreview succ.");
  2104. } else {
  2105. //RTA2N04
  2106. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetPreview_Close, "DevAdapter::CancelPreview", __FUNCTION__, false, ullEnd - ullStart, "", CombineJsonContext("OnDevExit::SetPreview(0)"));
  2107. }
  2108. }
  2109. } else if(ISSUCCEEDED(erroCode) && !status.isConnected){
  2110. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("HSPSCanner device is disconnected!");
  2111. }
  2112. }
  2113. CSimpleStringA strNoUsed(true);
  2114. GetCurImageName(strNoUsed);
  2115. DelAndGetNewFileName(strNoUsed);
  2116. GetCurImageName(strNoUsed, true);
  2117. DelAndGetNewFileName(strNoUsed);
  2118. return erroCode;
  2119. }
  2120. void CHSPScannerFSM::SelfTest(EntityTestEnum eTestType,
  2121. CSmartPointer<ITransactionContext> pTransactionContext)
  2122. {
  2123. OnHardwareShakeHand(pTransactionContext);
  2124. }
  2125. void CHSPScannerFSM::OnStateTrans(int iSrcState, int iDstState)
  2126. {
  2127. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("trans from %s to %s", GetStateName(iSrcState), GetStateName(iDstState));
  2128. m_nSrcState = iSrcState;
  2129. }
  2130. int CHSPScannerFSM::StartPreviewJS(SpReqAnsContext<HSPScannerService_StartPreviewJS_Req, HSPScannerService_StartPreviewJS_Ans>::Pointer ctx)
  2131. {
  2132. LOG_FUNCTION();
  2133. ErrorCodeEnum erroCode = Error_Unexpect;
  2134. int ret(0);
  2135. SetLastUserCode();
  2136. if(JS::PreviewSettings(ctx->Req).IsWorth()) {
  2137. erroCode = SetPreviewProperty(JS::PreviewSettings(ctx->Req), HSPScannerService_LogCode_StartPreviewJS);
  2138. if (FAILURED(erroCode)) {
  2139. ctx->Answer(Error_Unexpect, GetLastUserCode());
  2140. return 1;
  2141. }
  2142. }
  2143. //TODO: [Gifur@2025318]
  2144. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("Start to Preview...0x%X", GetAlarmDEC(MEC_DEVAPI_HSPSCANNER_SetPreview_Open));
  2145. ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  2146. erroCode = m_hDevHelper->SetPreview(1);
  2147. ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  2148. if (FAILURED(erroCode)) {
  2149. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetPreview_Open, "DevAdapter::SetPreview", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_StartPreviewJS, CombineJsonContext("StartPreview::SetPreview(1)"));
  2150. SetLastUserCode(GetAlarmDEC());
  2151. erroCode = Error_Unexpect;
  2152. ret = 1;
  2153. }
  2154. else {
  2155. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_StartPreviewJS).setAPI("DevAdapter::SetPreview").setCostTime(ullEnd - ullStart)("StartPreview::SetPreview(1)");
  2156. LogEvent(Severity_Middle, LOG_EVT_HSPS_LIGHT_ON, "HSPScanner warning on.");
  2157. }
  2158. ctx->Answer(erroCode, GetLastUserCode());
  2159. return ret;
  2160. }
  2161. int CHSPScannerFSM::CancelPreview(SpReqAnsContext<HSPScannerService_CancelPreviewJS_Req, HSPScannerService_CancelPreviewJS_Ans>::Pointer ctx)
  2162. {
  2163. LOG_FUNCTION();
  2164. ErrorCodeEnum erroCode = Error_Unexpect;
  2165. int ret(0);
  2166. SetLastUserCode();
  2167. if (ctx->Req.hide) {
  2168. erroCode = SetPreviewProperty(JS::PreviewSettings(false), HSPScannerService_LogCode_CancelPreviewJS);
  2169. if (FAILURED(erroCode)) {
  2170. ctx->Answer(Error_Unexpect, GetLastUserCode());
  2171. ret = 1;
  2172. }
  2173. else {
  2174. ctx->Answer(Error_Succeed);
  2175. }
  2176. }
  2177. else {
  2178. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_USER)("Start to CancelPreview...");
  2179. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  2180. erroCode = m_hDevHelper->SetPreview(0);
  2181. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  2182. if (ISSUCCEEDED(erroCode)) {
  2183. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_CancelPreviewJS).setAPI("DevAdapter::CancelPreview").setCostTime(ullEnd - ullStart)("SetPreview(0) succ");
  2184. ctx->Answer(Error_Succeed);
  2185. }
  2186. else {
  2187. //RTA2N04
  2188. SetErrorAndLog(erroCode, LOG_EVT_HSPS_CANCEL_PREVIEW_FAILED, "DevAdapter::CancelPreview", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_CancelPreviewJS, CombineJsonContext("SetPreview(0)"));
  2189. SetLastUserCode(GetAlarmDEC());
  2190. ctx->Answer(Error_Unexpect, GetLastUserCode());
  2191. ret = 1;
  2192. }
  2193. }
  2194. if (ISSUCCEEDED(erroCode)) {
  2195. LogEvent(Severity_Middle, LOG_EVT_HSPS_LIGHT_OFF, "HSPScanner warning off.");
  2196. }
  2197. return ret;
  2198. }
  2199. int CHSPScannerFSM::ScanImageJS(SpReqAnsContext<HSPScannerService_ScanImageJS_Req, HSPScannerService_ScanImageJS_Ans>::Pointer ctx)
  2200. {
  2201. LOG_FUNCTION();
  2202. ErrorCodeEnum erroCode = Error_Unexpect;
  2203. int ret(0);
  2204. SetLastUserCode();
  2205. CSimpleStringA csImageFile(true);
  2206. GetCurImageName(csImageFile);
  2207. ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  2208. erroCode = m_hDevHelper->ScanImage((LPCTSTR)csImageFile);
  2209. ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  2210. if (ISSUCCEEDED(erroCode)) {
  2211. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::ScanImage").setCostTime(ullEnd - ullStart)("DevAdapter::ScanImage succ");
  2212. if (ctx->Req.compress > 0 && !ResizeImage(csImageFile, ctx->Req.compress/*KB*/)) {
  2213. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setResultCode(MapCode2RTAString(LOG_WARN_HSPS_RESIZE_IMAGE_FILE_FAILED)).setAPI(__FUNCTION__).setLogCode(HSPScannerService_LogCode_ScanImageJS).setCostTime(ullEnd - ullStart)("HSPScanner resize image failed");
  2214. SetLastUserCode(LOG_WARN_HSPS_RESIZE_IMAGE_FILE_FAILED);
  2215. erroCode = Error_Unexpect;
  2216. ret = 1;
  2217. }
  2218. else {
  2219. CBlob& cbData = ctx->Ans.imageData;
  2220. FILE* fHandle = fopen(csImageFile, "rb");
  2221. if (fHandle) {
  2222. fseek(fHandle, 0, SEEK_END);
  2223. long fileSize = ftell(fHandle);
  2224. if (fileSize <= 0) {
  2225. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImageJS).setResultCode("RTA2N0S")("ftell(%s) error after invoking scanimage: %ld.", (LPCTSTR)csImageFile, fileSize);
  2226. }
  2227. else {
  2228. cbData.Alloc(fileSize);
  2229. fseek(fHandle, 0, SEEK_SET);
  2230. fread(cbData.m_pData, 1, fileSize, fHandle);
  2231. }
  2232. fclose(fHandle);
  2233. }
  2234. else {
  2235. DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImageJS).setResultCode("RTA2N0S")("fopen(%s) error after invoking scanimage: %d.", (LPCTSTR)csImageFile, errno);
  2236. }
  2237. if (ctx->Req.hide && FAILURED(SetPreviewProperty(JS::PreviewSettings(false), HSPScannerService_LogCode_ScanImageJS))) {
  2238. erroCode = Error_Unexpect;
  2239. ret = 1;
  2240. }
  2241. else {
  2242. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImageJS).setAPI(__FUNCTION__)("ScanImage succ");
  2243. }
  2244. }
  2245. }
  2246. else {
  2247. SetErrorAndLog(erroCode, LOG_EVT_HSPS_SCANIMAGE_FAILED, "DevAdapter::ScanImage", __FUNCTION__
  2248. , IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_ScanImageJS);
  2249. SetLastUserCode(GetAlarmDEC());
  2250. erroCode = Error_Unexpect;
  2251. ret = 1;
  2252. }
  2253. ctx->Answer(erroCode, GetLastUserCode());
  2254. return ret;
  2255. }
  2256. int CHSPScannerFSM::SetParam(SpReqAnsContext<HSPScannerService_SetParamJS_Req, HSPScannerService_SetParamJS_Ans>::Pointer ctx)
  2257. {
  2258. LOG_FUNCTION();
  2259. ErrorCodeEnum erroCode = Error_Unexpect;
  2260. int ret(0);
  2261. SetLastUserCode();
  2262. erroCode = SetPreviewProperty(JS::PreviewSettings(ctx->Req), HSPScannerService_LogCode_SetParamJS);
  2263. if (FAILURED(erroCode)) ret = 1;
  2264. ctx->Answer(erroCode, GetLastUserCode());
  2265. return ret;
  2266. }
  2267. ErrorCodeEnum CHSPScannerFSM::SetPreviewProperty(const JS::PreviewSettings& val, const char* logCode)
  2268. {
  2269. ErrorCodeEnum erroCode(Error_Succeed);
  2270. const bool isBusiness = (logCode == NULL || strlen(logCode) == 0) ? false : IsInBusiness();
  2271. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("to test:0x%X", GetAlarmDEC(MEC_DEVAPI_HSPSCANNER_SetParam));
  2272. if (val.color > 0 && val.color < 4) {
  2273. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  2274. erroCode = m_hDevHelper->SetParam(HSPS_MODEL_COLOR, Param_Color_Map[val.color]);
  2275. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  2276. if (ISSUCCEEDED(erroCode)) {
  2277. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)(ParamValToString(Param_Color_Map[val.color]));
  2278. }
  2279. else {
  2280. SetErrorAndLog(erroCode, HSPScanner_UserErrorCode_SetParam_Color, "DevAdapter::SetParam", __FUNCTION__, isBusiness, ullEnd - ullStart, logCode, CombineJsonContext(ParamValToString(Param_Color_Map[val.color])));
  2281. SetLastUserCode(GetAlarmDEC());
  2282. return erroCode;
  2283. }
  2284. }
  2285. //////////////////////////////////////////////////////////////////////////
  2286. if (val.rotate > 0 && val.rotate < 5) {
  2287. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  2288. erroCode = m_hDevHelper->SetParam(HSPS_MODEL_ROTATE, Param_Rotate_Map[val.rotate]);
  2289. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  2290. if (ISSUCCEEDED(erroCode)) {
  2291. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)(ParamValToString(Param_Rotate_Map[val.rotate]));
  2292. }
  2293. else {
  2294. SetErrorAndLog(erroCode, HSPScanner_UserErrorCode_SetParam_Rotate, "DevAdapter::SetParam", __FUNCTION__, isBusiness, ullEnd - ullStart, logCode, CombineJsonContext(ParamValToString(Param_Rotate_Map[val.rotate])));
  2295. SetLastUserCode(GetAlarmDEC());
  2296. return erroCode;
  2297. }
  2298. }
  2299. //////////////////////////////////////////////////////////////////////////
  2300. if (val.scan > 0 && val.scan < 4) {
  2301. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  2302. erroCode = m_hDevHelper->SetParam(HSPS_MODEL_SCANSIZE, Param_Scan_Map[val.scan]);
  2303. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  2304. if (ISSUCCEEDED(erroCode)) {
  2305. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)(ParamValToString(Param_Scan_Map[val.scan]));
  2306. }
  2307. else {
  2308. SetErrorAndLog(erroCode, HSPScanner_UserErrorCode_SetParam_Scan, "DevAdapter::SetParam", __FUNCTION__, isBusiness, ullEnd - ullStart, logCode, CombineJsonContext(ParamValToString(Param_Scan_Map[val.scan])));
  2309. SetLastUserCode(GetAlarmDEC());
  2310. return erroCode;
  2311. }
  2312. }
  2313. //////////////////////////////////////////////////////////////////////////
  2314. if (val.pos != 0) {
  2315. CSimpleStringA tmpParm = CSimpleStringA::Format("x(%d), y(%d), w(%d)", val.pos_x, val.pos_y, val.pos_w);
  2316. DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_USER)("Start to SetViewPos %s...", tmpParm.GetData());
  2317. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  2318. erroCode = m_hDevHelper->SetViewPos(val.pos_x, val.pos_y, val.pos_w);
  2319. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  2320. if (ISSUCCEEDED(erroCode)) {
  2321. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetViewPos").setCostTime(ullEnd - ullStart)(tmpParm);
  2322. m_nRecX = val.pos_x;
  2323. m_nRecY = val.pos_y;
  2324. m_nRecW = val.pos_w;
  2325. }
  2326. else {
  2327. //RTA2N07
  2328. SetErrorAndLog(erroCode, HSPScanner_UserErrorCode_SetParam_Position, "DevAdapter::SetViewPos", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, logCode, CombineJsonContext(tmpParm));
  2329. SetLastUserCode(GetAlarmDEC());
  2330. }
  2331. }
  2332. //////////////////////////////////////////////////////////////////////////
  2333. if (val.view != 0) {
  2334. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  2335. erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, Param_View_Map[val.view]);
  2336. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  2337. if (ISSUCCEEDED(erroCode)) {
  2338. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)(ParamValToString(Param_View_Map[val.view]));
  2339. }
  2340. else {
  2341. SetErrorAndLog(erroCode, val.view == 1 ? HSPScanner_UserErrorCode_SetParam_View : HSPScanner_UserErrorCode_SetParam_Hide
  2342. , "DevAdapter::SetParam", __FUNCTION__, isBusiness, ullEnd - ullStart, logCode, CombineJsonContext(ParamValToString(Param_View_Map[val.view])));
  2343. SetLastUserCode(GetAlarmDEC());
  2344. return erroCode;
  2345. }
  2346. }
  2347. return erroCode;
  2348. }
  2349. //TODO: JS完全替换后,这个函数要废弃换成上面的替代 [Gifur@2025318]
  2350. int CHSPScannerFSM::SetPreviewParam(int colorType, int rotateType, int scanType, bool abortIfFault)
  2351. {
  2352. ErrorCodeEnum erroCode;
  2353. int retCode = 0;
  2354. if (colorType > 0 && colorType < 4) {
  2355. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  2356. erroCode = m_hDevHelper->SetParam(HSPS_MODEL_COLOR, Param_Color_Map[colorType]);
  2357. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  2358. if (ISSUCCEEDED(erroCode)) {
  2359. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)(ParamValToString(Param_Color_Map[colorType]));
  2360. }
  2361. else {
  2362. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, abortIfFault ? IsInBusiness() : false, ullEnd - ullStart, HSPScannerService_LogCode_SetProperty, CombineJsonContext(ParamValToString(Param_Color_Map[colorType])));
  2363. retCode |= 0x0001;
  2364. SetLastUserCode(GetAlarmDEC(MEC_DEVAPI_HSPSCANNER_SetParam));
  2365. }
  2366. }
  2367. //////////////////////////////////////////////////////////////////////////
  2368. if (rotateType > 0 && rotateType < 5) {
  2369. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  2370. erroCode = m_hDevHelper->SetParam(HSPS_MODEL_ROTATE, Param_Rotate_Map[rotateType]);
  2371. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  2372. if (ISSUCCEEDED(erroCode)) {
  2373. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)(ParamValToString(Param_Rotate_Map[rotateType]));
  2374. }
  2375. else {
  2376. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, abortIfFault ? IsInBusiness() : false, ullEnd - ullStart, HSPScannerService_LogCode_SetProperty, CombineJsonContext(ParamValToString(Param_Rotate_Map[rotateType])));
  2377. retCode |= 0x0002;
  2378. SetLastUserCode(GetAlarmDEC(MEC_DEVAPI_HSPSCANNER_SetParam));
  2379. }
  2380. }
  2381. //////////////////////////////////////////////////////////////////////////
  2382. if (scanType > 0 && scanType < 4) {
  2383. const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
  2384. erroCode = m_hDevHelper->SetParam(HSPS_MODEL_SCANSIZE, Param_Scan_Map[scanType]);
  2385. const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
  2386. if (ISSUCCEEDED(erroCode)) {
  2387. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)(ParamValToString(Param_Scan_Map[scanType]));
  2388. }
  2389. else {
  2390. SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, abortIfFault ? IsInBusiness() : false, ullEnd - ullStart, HSPScannerService_LogCode_SetProperty, CombineJsonContext(ParamValToString(Param_Scan_Map[scanType])));
  2391. retCode |= 0x0004;
  2392. SetLastUserCode(GetAlarmDEC(MEC_DEVAPI_HSPSCANNER_SetParam));
  2393. }
  2394. }
  2395. return retCode;
  2396. }
  2397. void CHSPScannerFSM::InitialMaxResizeValue()
  2398. {
  2399. CSmartPointer<IEntityFunction> spFunction = this->GetEntityBase()->GetFunction();
  2400. CSmartPointer<IConfigInfo> spConfig;
  2401. spFunction->OpenConfig(Config_CenterSetting, spConfig);
  2402. int kb = 0;
  2403. spConfig->ReadConfigValueInt(GetEntityBase()->GetEntityName(), "ImageMaxSize", kb);
  2404. if (kb > 0) {
  2405. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("Get image max size from CS: %d", kb);
  2406. m_dwMaxImageSize = kb;
  2407. return;
  2408. }
  2409. }
  2410. ErrorCodeEnum CHSPScannerFSM::DeleteFileIfExisted(LPCTSTR fileName)
  2411. {
  2412. if (ExistsFileA(fileName)) {
  2413. if (RemoveFileA(fileName) != 0) {
  2414. return Error_Succeed;
  2415. } else {
  2416. LogWarn(Severity_High, Error_Unexpect, HSPScanner_UserErrorCode_CLEAR_RESOURCE_FAILED, CSimpleStringA::Format(
  2417. "DeleteFile(%s) failed LastError(%d) at ResizeImage proc", fileName, GetLastError()));
  2418. return Error_Unexpect;
  2419. }
  2420. } else {
  2421. return Error_Succeed;
  2422. }
  2423. }