myvtm/Module/mod_HSPScanner/HSPScannerFSM.cpp

#include "stdafx.h"
#include "HSPScannerFSM.h"
#include "EventCode.h"
#include "CommDevEntityErrorCode.h"
#include "RVCComm.h"
#include "publicFunExport.h"
#include "fileutil.h"
#include <math.h>

#ifndef _WIN32
#include <winpr/sysinfo.h>
#include "opencv.hpp"
#else
#include <opencv2/opencv.hpp>
#endif //NOT _WIN32

#define RESET_TIMER_ID 1
#define CHECK_CONNECT_TIMER_ID 2
const int MILLISECOND_TO_RESET = 30 * 1000;
const int MILLISECOND_TO_CHECK_CONNECT = 15 * 1000;

const int MAX_PATH_SIZE = 256;
const int MAX_IMAGEDATA_BUFSIZE = 1 * 1024*1024;
const int MAX_IMAGEDATA_SUFFIX = 1024;
const int MAX_ERROR_TIMES = 2;

#define TEMP_WIDTH 1280

#define T_STRINGY(var) case var: return #var; break;

const char* EvtTypeToString(int nEvtType)
{
	switch(nEvtType)
	{
		T_STRINGY(USER_EVT_STARTPREVIEW)
		T_STRINGY(USER_EVT_STARTPREVIEW_FINISHED)
		T_STRINGY(USER_EVT_STOPPREVIEW)
		T_STRINGY(USER_EVT_STOPPREVIEW_FINISHED)
		T_STRINGY(USER_EVT_SETWINPOS)
		T_STRINGY(USER_EVT_SETWINPOSFINISHED)
		T_STRINGY(USER_EVT_SCANIMAGE)
		T_STRINGY(USER_EVT_SCANIMAGE_EX)
		T_STRINGY(USER_EVT_SCANIMAGEFINISHED)
		T_STRINGY(USER_EVT_SETPROPERTY)
		T_STRINGY(USER_EVT_SETPROPERTY_FINISHED)
		T_STRINGY(USER_EVT_GETSTATUS)
		T_STRINGY(USER_EVT_GETINFO)
		T_STRINGY(USER_EVT_DISCONNECT)
		T_STRINGY(USER_EVT_EXIT)
		T_STRINGY(USER_EVT_QUIT)
		T_STRINGY(USER_EVT_RESET)
		T_STRINGY(USER_EVT_EXIT_FINISHED)
		T_STRINGY(USER_EVT_SHOWPROPERTY)
		T_STRINGY(USER_EVT_SHOWPROPERTY_FINISHED)
		T_STRINGY(EVT_TIMER)
		T_STRINGY(USER_EVT_SETPROPERTYINVIEW_FINISHED)
		T_STRINGY(USER_EVT_NOCFG)
		T_STRINGY(USER_EVT_HIDEPREVIEW)
		T_STRINGY(USER_EVT_GOTOHELL)
	default:
		return "Unknown EventType";
		break;
	}
}

const char* ParamValToString(int nParamVal)
{
	switch(nParamVal)
	{
        T_STRINGY(HSPS_BOOLVAL_FALSE)
        T_STRINGY(HSPS_BOOLVAL_TRUE)
        T_STRINGY(HSPS_COLOR_FULL)
        T_STRINGY(HSPS_COLOR_GREY)
        T_STRINGY(HSPS_ROTATE_NOANGLE)
        T_STRINGY(HSPS_ROTATE_LEFT)
        T_STRINGY(HSPS_ROTATE_MIRROR)
        T_STRINGY(HSPS_ROTATE_RIGHT)
        T_STRINGY(HSPS_SCAN_FULL)
        T_STRINGY(HSPS_SCAN_A4)
        T_STRINGY(HSPS_SCAN_IDCARD)
        T_STRINGY(HSPS_VIEW_HIDE)
        T_STRINGY(HSPS_VIEW_SHOW)
	default:
		return "Unknown ParamVal";
	}
}
#undef  T_STRINGY


LPCTSTR CHSPScannerFSM::MapCode2RTAString(DWORD dwValue)
{
	switch (dwValue) {
	case LOG_ERR_HSPS_DEVOPEN_FAILED:
		return "RTA2N01";
		break;
	case 0x21700002:
		return "RTA2N02";
		break;
	case 0x21700003:
		return "RTA2N03";
		break;
	case 0x21700004:
		return "RTA2N04";
		break;
	case 0x21700005:
		return "RTA2N05";
		break;
	case 0x21700006:
		return "RTA2N06";
		break;
	case 0x21700007:
		return "RTA2N07";
		break;
	case 0x21700008:
		return "RTA2N08";
		break;
	case 0x21700009:
		return "RTA2N09";
		break;
	case 0x2170000A:
		return "RTA2N0A";
		break;
	case 0x2170000B:
		return "RTA2N0B";
		break;
	case 0x2170000C:
		return "RTA2N0C";
		break;
	case HSPScanner_UserErrorCode_READ_IMAGE_FILE_FAILED:
		return "RTA2N0D";
		break;
	case HSPScanner_UserErrorCode_LOAD_DLLFILE_NOTEIXT:
		return "RTA2N0E";
		break;
	case HSPScanner_UserErrorCode_LOAD_DLLFILE_FAILED:
		return "RTA2N0F";
		break;
	case HSPScanner_UserErrorCode_FSM_INVALID:
		return "RTA2N0G";
		break;
	case HSPScanner_UserErrorCode_DLLNAME_FAILED:
		return "RTA2N0H";
		break;
	case HSPScanner_UserErrorCode_DLLNAME_NOCFG:
		return "RTA2N0J";
		break;
	case HSPScanner_UserErrorCode_DEVICE_OFFLINE:
		return "RTA2N0K";
		break;
	case HSPScanner_UserErrorCode_IMAGE_CLEAR:
		return "RTA2N0L";
		break;
	case HSPScanner_UserErrorCode_NOT_SUPPORT:
		return "RTA2N0M";
		break;
	case LOG_WARN_HSPS_RESIZE_IMAGE_FILE_FAILED:
		return "RTA2N0N";
		break;
	case HSPScanner_UserErrorCode_CLEAR_RESOURCE_FAILED:
		return "RTA2N0L";
		break;
		//return "RTA2N0Q";
	case 0:
	default:
		return "SUC0000";
		break;
	}
}

ParamTypeValue Param_Color_Map[4] = { HSPS_COLOR_FULL, HSPS_COLOR_FULL , HSPS_COLOR_GREY , HSPS_COLOR_FULL };
ParamTypeValue Param_Rotate_Map[5] = { HSPS_ROTATE_NOANGLE, HSPS_ROTATE_NOANGLE , HSPS_ROTATE_LEFT , HSPS_ROTATE_MIRROR,HSPS_ROTATE_RIGHT };
ParamTypeValue Param_Scan_Map[4] = { HSPS_SCAN_FULL, HSPS_SCAN_FULL , HSPS_SCAN_A4 , HSPS_SCAN_IDCARD };

CSimpleStringA CombineJsonContext(const char* szMessage)
{
	CSimpleStringA result(true);
	if (szMessage == NULL || strlen(szMessage) == 0) {
		return result;
	}
	result = CSimpleStringA::Format("{\"addition\": \"%s\"}", szMessage);
	return  result;
}

CHSPScannerFSM::CHSPScannerFSM(void)
	:
	m_version(0),
	m_batch(0),
	m_ecSelfTest(Error_Succeed),
	m_dwErroCode(0),
	m_bOperating(FALSE),
	m_nTickTimes(0),
	m_nFatalTimes(0),
	m_nSrcState(s0),
	m_csDevNo("Default"),
	m_eDevStatus(DEVICE_STATUS_NOT_READY),
	m_desiredAction(USER_EVT_QUIT),
	dwLastUserCode(0),
	m_dwMaxImageSize(500),
	m_csMachineType(true)
{
	HARDWARE_ENTITY_RESET_ENTITYID(m_entCode, 0x217);
	m_FirstStart = TRUE;
	m_errPkg.msgHead = "";
	m_errPkg.devSN = "";
	m_errPkg.devErrCode = Error_Unexpect;
	m_errPkg.apiErrCode = Error_Succeed;
}

CHSPScannerFSM::~CHSPScannerFSM(void)
{

}

ErrorCodeEnum CHSPScannerFSM::OnInit()
{
	LOG_FUNCTION();
	ErrorCodeEnum erroCode = Error_Succeed;
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Source Code complied at: %s %s", __DATE__, __TIME__);
	CSystemStaticInfo sysInfo;
	GetEntityBase()->GetFunction()->GetSystemStaticInfo(sysInfo);
	m_csMachineType = sysInfo.strMachineType;
	InitialMaxResizeValue();

	auto pEntity = GET_DEV_ENTITY_BASE_POINTER();
	pEntity->InitializeVendorLogSwitch();
	CSimpleStringA strNoUse(true);
	auto result = pEntity->ExtractVendorLibFullPath(strNoUse);
	if (result == Error_NotConfig) {
		PostEventLIFO(new FSMEvent(USER_EVT_NOCFG));
		m_bOpening = false;
		return Error_Succeed;
	}
	if (FAILURED(result)) {
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Fetch Vendor dllName failed %s(%s).", (LPCTSTR)strNoUse, SpStrError(result));
		goto FAIL;
	}
	FulfillAdapterInfoFrom(pEntity->vendorLibInfo);
	LogWarn(Severity_Low, Error_Unexpect, HSPScanner_UserErrorCode_ROOT_INFO, (LPCTSTR)m_adapterInfo.adapterFilePath);
	erroCode = LoadUpAdapterLibrary();

	if (erroCode == Error_Succeed) {
		if (Error_Succeed == (erroCode = TryToOpenDevice())) {
			m_eDevStatus = DEVICE_STATUS_NORMAL;
			ToLogRootINIInfo();
			ToLogWarnInfoAboutTerm();
			return erroCode;
		}
	}
	else if (erroCode == Error_NotExist) {
		SetLastUserCode(HSPScanner_UserErrorCode_LOAD_DLLFILE_NOTEIXT);
	}
	else {
		SetLastUserCode(HSPScanner_UserErrorCode_LOAD_DLLFILE_FAILED);
	}

FAIL:
	m_bOpened = false;
	m_bOpening = false;
	
	PostEventLIFO(new FSMEvent(USER_EVT_GOTOHELL));
	return Error_Succeed;
}

ErrorCodeEnum CHSPScannerFSM::OnExit()
{
	if (m_hDevHelper) {
		ErrorCodeEnum errCode = Error_Succeed;
		m_hDevHelper.TearDown();
		return errCode;
	}
	return Error_Succeed;
}

void CHSPScannerFSM::s0_on_entry()
{
	m_bOperating = FALSE;
	m_nFatalTimes = 0;
	m_ecSelfTest = Error_Succeed;
}

void CHSPScannerFSM::s0_on_exit()
{
	m_bOperating = FALSE;
}

unsigned int CHSPScannerFSM::s0_on_event(FSMEvent* e)
{
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s0_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
	unsigned int uRet = 0;
	switch(e->iEvt)
	{
	case USER_EVT_STARTPREVIEW:
		{
			StartPreviewTask* pTask = new StartPreviewTask(this);
			StartPreviewEvent* pEvt = dynamic_cast<StartPreviewEvent*>(e);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
			e->SetHandled();
		}
		break;
	case USER_EVT_STARTPREVIEW_FINISHED:
		{
			uRet = e->param1;
			e->SetHandled();
			if(uRet == 1 && ++m_nFatalTimes <= MAX_ERROR_TIMES)
			{
				uRet = 2;
			}
			else if(uRet == 0)
			{
				m_nFatalTimes = 0;
			}

			if(uRet == 2 && IsDevConnected() == 0)
			{
				PostEventFIFO(new FSMEvent(USER_EVT_DISCONNECT));
			}
			else if(uRet == 1) {
				m_desiredAction = USER_EVT_STARTPREVIEW;
			}
		}
		break;
		// Add after ST !!! --Josephus at 12:37:15 2016129
	case USER_EVT_SETWINPOS:
		{
			SetWinPosEvent* pEvt = dynamic_cast<SetWinPosEvent*>(e);
			if(pEvt->m_ctx->Req.type == 2)
			{//在s0状态，仅能用于设置位置和窗体大小
				SetWinPosTask* pTask = new SetWinPosTask(this);
				pTask->SetContext(pEvt->m_ctx);
				GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
				e->SetHandled();
			}
		}
		break;
	case USER_EVT_SETPROPERTY:
		{
			SetPropertyEvent* pEvt = dynamic_cast<SetPropertyEvent*>(e);
			SetProperty(pEvt->m_ctx);
			e->SetHandled();
		}
		break;
	case USER_EVT_DISCONNECT:
		{
			//jump auto.
		}
		e->SetHandled();
		break;
	case USER_EVT_GETSTATUS:
		{
			GetDevStatusTask* pTask = new GetDevStatusTask(this);
			GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
		}
		e->SetHandled();
		break;
	case USER_EVT_GETINFO:
	{
		GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
		if (!m_bOpened) {
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevInfo).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
			pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
		}
		else {
			GetDevInfoTask* pTask = new GetDevInfoTask(this);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
		}
	}
	e->SetHandled();
	break;
	case USER_EVT_NOCFG:
		{
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("HSPScaner is not cofig now.");
		}
		break;
	case USER_EVT_EXIT:
	{
		e->SetHandled();
		CSimpleStringA strNoUsed(true);
		GetCurImageName(strNoUsed);
		DelAndGetNewFileName(strNoUsed);
		GetCurImageName(strNoUsed, true);
		DelAndGetNewFileName(strNoUsed);
	}
	break;
	case USER_EVT_GOTOHELL:
		e->SetHandled();
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("HSPScaner init failed!");
		break;
	default:
		{
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("UnHandle event ! %d", e->iEvt);
		}
		break;
	}
	return uRet;
}

void CHSPScannerFSM::s1_on_entry()
{
	LOG_FUNCTION();
}

void CHSPScannerFSM::s1_on_exit()
{

}

unsigned int CHSPScannerFSM::s1_on_event(FSMEvent* e)
{
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s1_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
	unsigned int uRet = 0;
	switch(e->iEvt)
	{
	case USER_EVT_STARTPREVIEW:
		{
			// Maybe Just SetProperty [Josephus in 15:44:43 2016/11/19]
			SetPropertyInPreviewTask* pTask = new SetPropertyInPreviewTask(this);
			StartPreviewEvent* pEvt = dynamic_cast<StartPreviewEvent*>(e);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
			e->SetHandled();
		}
		break;
	case USER_EVT_SETPROPERTYINVIEW_FINISHED:
		{
			
		}
		e->SetHandled();
		break;
	case USER_EVT_STOPPREVIEW:
		{
			StopPreviewTask* pTask = new StopPreviewTask(this);
			StopPreviewEvent* pEvt = dynamic_cast<StopPreviewEvent*>(e);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
		}
		e->SetHandled();
		break;
	case USER_EVT_STOPPREVIEW_FINISHED:
		{
			uRet = e->param1;
			if((uRet == 0 || uRet == 4) && ++m_nFatalTimes <= MAX_ERROR_TIMES)
			{
				DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("hold on, wait next time (%d/%d).", m_nFatalTimes, MAX_ERROR_TIMES);
				uRet = 3;
			}
			else if(uRet != 0)
			{
				m_nFatalTimes = 0;
			}

			if(uRet == 3 && IsDevConnected() == 0)
			{
				PostEventFIFO(new FSMEvent(USER_EVT_DISCONNECT));
			}
			else if(uRet == 0) {
				m_desiredAction = USER_EVT_STOPPREVIEW;
			}
			else if(uRet == 4) {
				m_desiredAction = USER_EVT_HIDEPREVIEW;
			}
		}
		e->SetHandled();
		break;
	case USER_EVT_SCANIMAGE:
		{
			ScanImageTask* pTask = new ScanImageTask(this);
			ScanImageEvent* pEvt = dynamic_cast<ScanImageEvent*>(e);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
		}
		e->SetHandled();
		break;
	case USER_EVT_SCANIMAGE_EX:
		{
			ScanImageExTask* pTask = new ScanImageExTask(this);
			ScanImageExEvent* pEvt = dynamic_cast<ScanImageExEvent*>(e);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
		}
		e->SetHandled();
		break;

	case USER_EVT_SETPROPERTY:
		{
			SetPropertyEvent* pEvt = dynamic_cast<SetPropertyEvent*>(e);
			SetProperty(pEvt->m_ctx);
		}
		e->SetHandled();
		break;
	case USER_EVT_SHOWPROPERTY:
		{
			ShowPropertyTask* pTask = new ShowPropertyTask(this);
			ShowPropertyEvent* pEvt = dynamic_cast<ShowPropertyEvent*>(e);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
		}
		e->SetHandled();
		break;
	case USER_EVT_SETWINPOS:
		{
			SetWinPosEvent* pEvt = dynamic_cast<SetWinPosEvent*>(e);
			SetWinPosTask* pTask = new SetWinPosTask(this);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
		}
		e->SetHandled();
		break;
	case USER_EVT_DISCONNECT:
		{
			//jump auto.
		}
		e->SetHandled();
		break;
	case USER_EVT_GETSTATUS:
		{
			GetDevStatusTask* pTask = new GetDevStatusTask(this);
			GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
		}
		e->SetHandled();
		break;
	case USER_EVT_GETINFO:
		{
			GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
			if (!m_bOpened) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevInfo).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
				pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
			}
			else {
				GetDevInfoTask* pTask = new GetDevInfoTask(this);
				pTask->SetContext(pEvt->m_ctx);
				GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
			}
		}
		e->SetHandled();
		break;
	}
	return uRet;
}

void CHSPScannerFSM::s2_on_entry()
{
	LOG_FUNCTION();
}

void CHSPScannerFSM::s2_on_exit()
{

}

unsigned int CHSPScannerFSM::s2_on_event(FSMEvent* e)
{
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s2_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
	unsigned int uRet = 0;
	switch(e->iEvt)
	{
	case USER_EVT_SHOWPROPERTY_FINISHED:
		{

		}
		e->SetHandled();
		break;
	case USER_EVT_GETSTATUS:
		{
			GetDevStatusTask* pTask = new GetDevStatusTask(this);
			GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
		}
		e->SetHandled();
		break;
	case USER_EVT_GETINFO:
		{
			GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
			if (!m_bOpened) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevInfo).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
				pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
			}
			else {
				GetDevInfoTask* pTask = new GetDevInfoTask(this);
				pTask->SetContext(pEvt->m_ctx);
				GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
			}
		}
		e->SetHandled();
		break;
	}
	return uRet;
}

void CHSPScannerFSM::s3_on_entry()
{
	LOG_FUNCTION();
	
	m_eDevStatus = DEVICE_STATUS_FAULT;

	m_nTickTimes = 0;
	m_bOperating = FALSE;

	const int nStatus = IsDevConnected();
	if (nStatus == 0) {
		PostEventFIFO(new FSMEvent(USER_EVT_DISCONNECT));
	} else {
		if (nStatus != -1) {
			ScheduleTimer(RESET_TIMER_ID, MILLISECOND_TO_RESET / 6);
		}
	}
}

void CHSPScannerFSM::s3_on_exit()
{
	m_eDevStatus = DEVICE_STATUS_NORMAL;
	m_bOperating = FALSE;
	m_ecSelfTest = Error_Succeed;
	m_nFatalTimes = 0;
	m_desiredAction = USER_EVT_QUIT;
	CancelTimer(RESET_TIMER_ID);
}

unsigned int CHSPScannerFSM::s3_on_event(FSMEvent* e)
{
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s3_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
	unsigned int uRet = 0;
	switch(e->iEvt)
	{
	case USER_EVT_STARTPREVIEW:
		{
			StartPreviewEvent* pEvt = dynamic_cast<StartPreviewEvent*>(e);
			if (!m_bOpened) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_StartPreview).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
				pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
			} else {
				StartPreviewTask* pTask = new StartPreviewTask(this);
				pTask->SetContext(pEvt->m_ctx);
				GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
			}
			e->SetHandled();
		}
		break;
	case USER_EVT_STARTPREVIEW_FINISHED:
		{
			uRet = e->param1;
			e->SetHandled();
		}
		break;
	case USER_EVT_STOPPREVIEW:
		{
			if(m_hDevHelper && m_bOpened)
			{
				CancelTimer(RESET_TIMER_ID);
				StopPreviewEvent* pEvt = dynamic_cast<StopPreviewEvent*>(e);
				HspsDevStatus status = {0};
				ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
				ErrorCodeEnum erroCode = m_hDevHelper->GetDevStatus(status);
				ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
				if (erroCode == Error_Succeed) {
					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);
				} else {
					//RTA2N09
					SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_GetDevStatus, "DevAdapter::GetDevStatus", __FUNCTION__, IsInBusiness(), ullEnd - ullStart);
				}
				if (status.inPreview == 1) {
					StopPreviewTask* pTask = new StopPreviewTask(this);
					pTask->SetContext(pEvt->m_ctx);
					GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
				} else if (status.inShow == 1) {
					ullStart = SP::Module::Comm::RVCGetTickCount();
					erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
					ullEnd = SP::Module::Comm::RVCGetTickCount();
					if (ISSUCCEEDED(erroCode)) {
						DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_CancelPreview).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)("HSPS_VIEW_HIDE");
					} else {
						//RTA2N0Q
						SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_CancelPreview, CombineJsonContext("HSPS_VIEW_HIDE failed"));
						SetLastUserCode(GetAlarmDEC());
					}
					pEvt->m_ctx->Answer(TransECWithRepeat(erroCode));
					FSMEvent* timerEvent = new FSMEvent(EVT_TIMER);
					timerEvent->param1 = RESET_TIMER_ID;
					PostEventFIFO(timerEvent);
				}
			} else if (!m_bOpened) {
				StopPreviewEvent* pEvt = dynamic_cast<StopPreviewEvent*>(e);
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_CancelPreview).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
				pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
			} 
		}
		e->SetHandled();
		break;
	case USER_EVT_STOPPREVIEW_FINISHED:
		{
			uRet = e->param1;
			if(uRet == 0) {
				m_desiredAction = USER_EVT_STOPPREVIEW;
			}
			else if(uRet == 4) {
				m_desiredAction = USER_EVT_HIDEPREVIEW;
			}

			FSMEvent* timerEvent = new FSMEvent(EVT_TIMER);
			timerEvent->param1 = RESET_TIMER_ID;
			PostEventFIFO(timerEvent);
		}
		e->SetHandled();
		break;
	case USER_EVT_OPENSUCC:
		///*TODO(80374374@9/2/2022):  */
		e->SetHandled();
		break;
	case USER_EVT_RESET:
		{
		if (m_bOpened) {
			ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
			ErrorCodeEnum erroCode = m_hDevHelper->Reset();
			ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
			if (FAILURED(erroCode)) {
				//RTA2N0B
				SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_Reset, "DevAdapter::Reset", __FUNCTION__, false, ullEnd - ullStart, HSPScannerService_CustomLogCode_Reset);
				m_ecSelfTest = Error_InvalidState;
				uRet = 1;
			} else {
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::Reset").setCostTime(ullEnd - ullStart)("Reset");
				ullStart = SP::Module::Comm::RVCGetTickCount();
				ErrorCodeEnum eXYW = m_hDevHelper->SetViewPos(m_nRecX, m_nRecY, m_nRecW);
				ullEnd = SP::Module::Comm::RVCGetTickCount();
				if (FAILURED(eXYW)) {
					//RTA2N07
					SetErrorAndLog(eXYW, MEC_DEVAPI_HSPSCANNER_SetViewPos, "DevAdapter::SetViewPos", __FUNCTION__, false, ullEnd - ullStart, HSPScannerService_CustomLogCode_Reset);
					uRet = 1;
					m_ecSelfTest = Error_InvalidState;
					e->SetHandled();
					break;
				} else {
					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));
				}
				HspsDevStatus status = {0};
				do 
				{
					ullStart = SP::Module::Comm::RVCGetTickCount();
					erroCode = m_hDevHelper->GetDevStatus(status);
					ullEnd = SP::Module::Comm::RVCGetTickCount();
					if (erroCode == Error_Succeed) {
						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);
					} else {
						SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_GetDevStatus, "DevAdapter::GetDevStatus", __FUNCTION__, false, ullEnd - ullStart, HSPScannerService_CustomLogCode_Reset);
					}
				} while (false);
				if (status.inPreview == 1 && status.inShow == 1) {
					if (m_desiredAction == USER_EVT_STOPPREVIEW) {
						do 
						{
							ullStart = SP::Module::Comm::RVCGetTickCount();
							erroCode = m_hDevHelper->SetPreview(0);
							ullEnd = SP::Module::Comm::RVCGetTickCount();
							if (erroCode == Error_Succeed) {
								DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::CancelPreview").setCostTime(ullEnd - ullStart)();
							} else {
								//RTA2N04
								SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetPreview_Close, "DevAdapter::CancelPreview", __FUNCTION__, false, ullEnd - ullStart, HSPScannerService_CustomLogCode_Reset);
							}
						} while (false);
						{
							HspsDevStatus retryStatus = { 0 };
							do 
							{
								ullStart = SP::Module::Comm::RVCGetTickCount();
								const ErrorCodeEnum tmpErr = m_hDevHelper->GetDevStatus(retryStatus);
								ullEnd = SP::Module::Comm::RVCGetTickCount();
								if (tmpErr == Error_Succeed) {
									DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::GetDevStatus").setCostTime(ullEnd - ullStart)("preview:%d, show:%d, connect:%d", status.inPreview, status.inShow, status.isConnected);
								} else {
									//
									SetErrorAndLog(tmpErr, MEC_DEVAPI_HSPSCANNER_GetDevStatus, "DevAdapter::GetDevStatus", __FUNCTION__, false, ullEnd - ullStart, HSPScannerService_CustomLogCode_Reset);
								}
							} while (false);
							if (retryStatus.inPreview == 1) {
								do 
								{
									ullStart = SP::Module::Comm::RVCGetTickCount();
									erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
									ullEnd = SP::Module::Comm::RVCGetTickCount();
									if (erroCode == Error_Succeed) {
										DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)("HSPS_MODEL_VIEW, HSPS_VIEW_HIDE");
									} else {
										//RTA2N0Q
										SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, false, ullEnd - ullStart, HSPScannerService_CustomLogCode_Reset, CombineJsonContext("HSPS_VIEW_HIDE"));
									}
								} while (false);
							}
						}
					} else if (m_desiredAction == USER_EVT_HIDEPREVIEW) {
						do 
						{
							ullStart = SP::Module::Comm::RVCGetTickCount();
							erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
							ullEnd = SP::Module::Comm::RVCGetTickCount();
							if (erroCode == Error_Succeed) {
								DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)("HSPS_VIEW_HIDE");
							} else {
								//RTA2N0Q
								SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, false, ullEnd - ullStart, HSPScannerService_CustomLogCode_Reset, CombineJsonContext("HSPS_VIEW_HIDE"));
							}
						} while (false);
					}
					if (FAILURED(erroCode)) {
						DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Recover failed under desiration of %s", EvtTypeToString(m_desiredAction));
						uRet = 1;
						m_ecSelfTest = Error_InvalidState;
						e->SetHandled();
						break;
					}
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setLogCode(HSPScannerService_CustomLogCode_Reset)("Recover routine done");
					uRet = 2;
				}
			}
		}
		}
		e->SetHandled();
		break;
	case EVT_TIMER:
		{
			if (e->param1 == RESET_TIMER_ID) {
				FSMEvent* pEvt = new FSMEvent(USER_EVT_RESET);
				PostEventFIFO(pEvt);
				ScheduleTimer(RESET_TIMER_ID, MILLISECOND_TO_RESET);
			}
		}
		e->SetHandled();
		break;
	case USER_EVT_DISCONNECT:
		e->SetHandled();
		break;
	case USER_EVT_GETSTATUS:
		{
			GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
			if (!m_bOpened) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevStatus).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
				pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
			} else {
				GetDevStatusTask* pTask = new GetDevStatusTask(this);
				pTask->SetContext(pEvt->m_ctx);
				GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
			}
		}
		e->SetHandled();
		break;
	case USER_EVT_GETINFO:
		{
			GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
			if (!m_bOpened) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevInfo).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
				pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
			} else {
				GetDevInfoTask* pTask = new GetDevInfoTask(this);
				pTask->SetContext(pEvt->m_ctx);
				GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
			}
		}
		e->SetHandled();
		break;
	case USER_EVT_SETWINPOS:
	{
		SetWinPosEvent* pEvt = dynamic_cast<SetWinPosEvent*>(e);
        if (!m_bOpened) {
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_SetWinPos).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
            pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
			e->SetHandled();
		}
	}
    break;
	}
	return uRet;
}

void CHSPScannerFSM::s4_on_entry()
{
}

void CHSPScannerFSM::s4_on_exit()
{

}

unsigned int CHSPScannerFSM::s4_on_event(FSMEvent* e)
{
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s4_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
	unsigned int uRet = 0;
	switch(e->iEvt)
	{
	case USER_EVT_SCANIMAGEFINISHED:
		{
			uRet = e->param1;
			if(uRet == 2 && ++m_nFatalTimes < MAX_ERROR_TIMES)
			{
				DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("hold on, wait next time (%d/%d).", m_nFatalTimes, MAX_ERROR_TIMES);
				uRet = 5;
			}
			else if(uRet == 0)
			{
				m_nFatalTimes = 0;
			}

			if(uRet == 5 && IsDevConnected() == 0)
			{
				PostEventFIFO(new FSMEvent(USER_EVT_DISCONNECT));
			}
			else if(uRet == 2 || uRet == 4)
			{
				m_desiredAction = USER_EVT_SCANIMAGE;
			}
		}
		e->SetHandled();
		break;
	case USER_EVT_DISCONNECT:
		{
			//jump auto.
		}
		e->SetHandled();
		break;
	case USER_EVT_GETSTATUS:
		{
			GetDevStatusTask* pTask = new GetDevStatusTask(this);
			GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
		}
		e->SetHandled();
		break;
	case USER_EVT_GETINFO:
		{
			GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
			if (!m_bOpened) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevInfo).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
				pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
			}
			else {
				GetDevInfoTask* pTask = new GetDevInfoTask(this);
				pTask->SetContext(pEvt->m_ctx);
				GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
			}
		}
		e->SetHandled();
	break;
	}
	return uRet;
}

void CHSPScannerFSM::s5_on_entry()
{
	m_eDevStatus = DEVICE_STATUS_MAINTAINCE;
	LogEvent(Severity_Middle,LOG_EVT_HSPS_LOST_CONNECT,"高拍仪断开连接！");
	SetLastUserCode(HSPScanner_UserErrorCode_DEVICE_OFFLINE);
	ScheduleTimer(CHECK_CONNECT_TIMER_ID, MILLISECOND_TO_CHECK_CONNECT);
}

void CHSPScannerFSM::s5_on_exit()
{
	SetLastUserCode();
	m_eDevStatus = DEVICE_STATUS_NORMAL;
	CancelTimer(CHECK_CONNECT_TIMER_ID);
}

unsigned int CHSPScannerFSM::s5_on_event(FSMEvent* e)
{
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s5_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
	unsigned int uRet = 0;
	switch(e->iEvt)
	{
	case EVT_TIMER:
	{
		if (e->param1 == CHECK_CONNECT_TIMER_ID) {
			HspsDevStatus status = { 0 };
			const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
			ErrorCodeEnum eResult = m_hDevHelper->GetDevStatus(status);
			const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
			if (ISSUCCEEDED(eResult)) {
				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);
				if (status.isConnected == 0) {
					ScheduleTimer(CHECK_CONNECT_TIMER_ID, MILLISECOND_TO_CHECK_CONNECT);
				} else if (status.inShow == 1 && status.inPreview == 1) {
					//回到预览状态
					uRet = 2;
				} else {
					uRet = 1;
				}
			} else {
				//RTA2N09
				SetErrorAndLog(eResult, MEC_DEVAPI_HSPSCANNER_GetDevStatus, "DevAdapter::GetDevStatus", __FUNCTION__, false, ullEnd - ullStart);
			}
			e->SetHandled();
		}
	}
		break;
	case USER_EVT_GETSTATUS:
		{
			GetDevStatusTask* pTask = new GetDevStatusTask(this);
			GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
		}
		e->SetHandled();
		break;
	case USER_EVT_GETINFO:
		{
			GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
			if (!m_bOpened) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevInfo).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
				pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
			}
			else {
				GetDevInfoTask* pTask = new GetDevInfoTask(this);
				pTask->SetContext(pEvt->m_ctx);
				GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
			}
		}
		e->SetHandled();
	break;
    case USER_EVT_SETWINPOS:
    {
        SetWinPosEvent* pEvt = dynamic_cast<SetWinPosEvent*>(e);
		pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
    }
	e->SetHandled();
    break;
	}
	return uRet;
}

void CHSPScannerFSM::s6_on_entry()
{
}

void CHSPScannerFSM::s6_on_exit()
{

}

unsigned int CHSPScannerFSM::s6_on_event(FSMEvent* e)
{
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s6_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
	unsigned int uRet = 0;
	switch(e->iEvt)
	{
	case USER_EVT_STARTPREVIEW:
		{
			StartPreviewTask* pTask = new StartPreviewTask(this);
			StartPreviewEvent* pEvt = dynamic_cast<StartPreviewEvent*>(e);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
			e->SetHandled();
		}
		break;
	case USER_EVT_STARTPREVIEW_FINISHED:
	{
		uRet = e->param1;
		e->SetHandled();
		if (uRet == 1 && ++m_nFatalTimes < MAX_ERROR_TIMES) {
			DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("hold on, wait next time (%d/%d).", m_nFatalTimes, MAX_ERROR_TIMES);
			uRet = 2;
		} else if (uRet == 0) {
			m_nFatalTimes = 0;
		}

		if (uRet == 2 && IsDevConnected() == 0) {
			PostEventFIFO(new FSMEvent(USER_EVT_DISCONNECT));
		} else if (uRet == 1) {
			m_desiredAction = USER_EVT_STARTPREVIEW;
		}
	}
		break;
	case USER_EVT_SETPROPERTY:
		{
			SetPropertyEvent* pEvt = dynamic_cast<SetPropertyEvent*>(e);
			SetProperty(pEvt->m_ctx);
			e->SetHandled();
		}
		break;
	case USER_EVT_STOPPREVIEW:
		{
			StopPreviewEvent* pEvt = dynamic_cast<StopPreviewEvent*>(e);
			if(!pEvt->m_ctx->Req.bOnlyHide)
			{//业务在s6状态仅能进行彻底取消预览的操作
				StopPreviewTask* pTask = new StopPreviewTask(this);
				pTask->SetContext(pEvt->m_ctx);
				GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
				e->SetHandled();
			}
		}
		break;
	case USER_EVT_STOPPREVIEW_FINISHED:
		{
			uRet = e->param1;
			if (uRet == 0 && ++m_nFatalTimes < MAX_ERROR_TIMES) {
				uRet = 3;
			} else if (uRet != 0) {
				m_nFatalTimes = 0;
			}

			if (uRet == 3 && IsDevConnected() == 0) {
				PostEventFIFO(new FSMEvent(USER_EVT_DISCONNECT));
			}
		}
		e->SetHandled();
		break;
	case USER_EVT_SETWINPOS:
		{
			SetWinPosEvent* pEvt = dynamic_cast<SetWinPosEvent*>(e);
			if(pEvt->m_ctx->Req.type == 2)
			{//在s6状态，不允许进行显示和隐藏操作，业务必须通过XXXPreview来进行显示隐藏操作
				SetWinPosTask* pTask = new SetWinPosTask(this);
				pTask->SetContext(pEvt->m_ctx);
				GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
				e->SetHandled();
			}
		}
		break;
	case USER_EVT_DISCONNECT:
		{
			//jump auto.
		}
		e->SetHandled();
		break;
	case USER_EVT_GETSTATUS:
		{
			GetDevStatusTask* pTask = new GetDevStatusTask(this);
			GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
		}
		e->SetHandled();
		break;
	case USER_EVT_GETINFO:
		{
			GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
			if (!m_bOpened) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevInfo).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
				pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
			}
			else {
				GetDevInfoTask* pTask = new GetDevInfoTask(this);
				pTask->SetContext(pEvt->m_ctx);
				GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
			}
		}
		e->SetHandled();
		break;
	}
	return uRet;
}

void CHSPScannerFSM::s7_on_entry()
{
	LOG_FUNCTION();
	FSMEvent* pEvt = new FSMEvent(USER_EVT_EXIT_FINISHED);

	if (ISSUCCEEDED(OnDevExit())) {
		pEvt->param1 = 0;
	} else {
		pEvt->param1 = 1;
	}
	PostEventFIFO(pEvt);
}

void CHSPScannerFSM::s7_on_exit()
{
	if(m_hDevHelper && m_bOpened)
	{
		HspsDevStatus status = {0};
		const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
		ErrorCodeEnum erroCode = m_hDevHelper->GetDevStatus(status);
		const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
		if (erroCode == Error_Succeed) {
			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);
		} else {
			//RTA2N09
			SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_GetDevStatus, "DevAdapter::GetDevStatus", __FUNCTION__, false, ullEnd - ullStart);
		}
		/** nothing to do now, plan to remove it? Gifur@2024220]*/
	}
}

unsigned int CHSPScannerFSM::s7_on_event(FSMEvent* e)
{
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s7_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
	unsigned int uRet = 0;
	switch(e->iEvt)
	{
	case USER_EVT_EXIT_FINISHED:
		{
			uRet = e->param1;
			if (uRet == 1) {
				m_desiredAction = USER_EVT_EXIT;
			}
		}
		e->SetHandled();
		break;
	case USER_EVT_GETSTATUS:
		{
			GetDevStatusTask* pTask = new GetDevStatusTask(this);
			GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
		}
		e->SetHandled();
		break;
	case USER_EVT_GETINFO:
		{
			GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
			if (!m_bOpened) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevInfo).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
				pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
			}
			else {
				GetDevInfoTask* pTask = new GetDevInfoTask(this);
				pTask->SetContext(pEvt->m_ctx);
				GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
			}
		}
		e->SetHandled();
		break;
	}
	return uRet;
}

unsigned int CHSPScannerFSM::s8_on_event(FSMEvent* e)
{
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s8_on_event: %s(%d), %d.", EvtTypeToString(e->iEvt), e->iEvt, e->param1);
	unsigned int uRet = 0;
	switch (e->iEvt) {
	case USER_EVT_STARTPREVIEW:
	{
		StartPreviewEvent* pEvt = dynamic_cast<StartPreviewEvent*>(e);
		pEvt->SetHandled();
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_StartPreview).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG");
		pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
	}
	break;
	case USER_EVT_STOPPREVIEW:
	{
		StopPreviewEvent* pEvt = dynamic_cast<StopPreviewEvent*>(e);
		pEvt->SetHandled();
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_CancelPreview).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG");
		pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
	}
	break;
	case USER_EVT_SCANIMAGE:
	{
		ScanImageEvent* pEvt = dynamic_cast<ScanImageEvent*>(e);
		pEvt->SetHandled();
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImage).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG");
		pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
	}
	break;
	case USER_EVT_SCANIMAGE_EX:
	{
		ScanImageExEvent* pEvt = dynamic_cast<ScanImageExEvent*>(e);
		pEvt->SetHandled();
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImageEx).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG");
		pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
	}
	break;
	case USER_EVT_SHOWPROPERTY:
	{
		ShowPropertyEvent* pEvt = dynamic_cast<ShowPropertyEvent*>(e);
		pEvt->SetHandled();
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ShowProperty).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG");
		pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
	}
	break;
	case USER_EVT_SETPROPERTY:
	{
		SetPropertyEvent* pEvt = dynamic_cast<SetPropertyEvent*>(e);
		pEvt->SetHandled();
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_SetProperty).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG");
		pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
	}
	break;
	case USER_EVT_SETWINPOS:
	{
		SetWinPosEvent* pEvt = dynamic_cast<SetWinPosEvent*>(e);
		pEvt->SetHandled();
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_SetWinPos).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG");
		pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
	}
	break;
	case USER_EVT_GETSTATUS:
	{
		GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
		pEvt->SetHandled();
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevStatus).setResultCode(MapCode2RTAString(GetLastUserCode()))("NOCFG");
		pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
	}
	break;
	case USER_EVT_GETINFO:
	{
		GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
		if (!m_bOpened) {
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevInfo).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
			pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
		}
		else {
			GetDevInfoTask* pTask = new GetDevInfoTask(this);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
		}
	}
	e->SetHandled();
	break;
	default:
		break;
	}
	return uRet;
}

int CHSPScannerFSM::StartPreview(SpReqAnsContext<HSPScannerService_StartPreview_Req,
	HSPScannerService_StartPreview_Ans>::Pointer ctx)
{
	bool nRes = 0;
	ErrorCodeEnum erroCode = Error_Unexpect;
	SetLastUserCode();
	if (ctx->Req.colorType || ctx->Req.scanType || ctx->Req.rotateType) {
		const int retCode = SetPreviewParam(ctx->Req.colorType, ctx->Req.rotateType, ctx->Req.scanType);
		if (retCode != 0)
		{
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("SetPreviewParam return some wrong:0x%X", retCode);
			erroCode = Error_DevCommFailed;
		}
		else {
			erroCode = Error_Succeed;
		}
	}
	HspsDevStatus status = { 0 };
	ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
	erroCode = m_hDevHelper->GetDevStatus(status);
	ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
	if (erroCode == Error_Succeed) {
		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);
	}
	if (ISSUCCEEDED(erroCode) && status.inPreview) {// 用于s6状态 [Josephus in 9:33:48 2016/11/22]
		ullStart = SP::Module::Comm::RVCGetTickCount();
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_SHOW);
		ullEnd = SP::Module::Comm::RVCGetTickCount();
		if (ISSUCCEEDED(erroCode)) {
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_StartPreview).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)("HSPS_VIEW_SHOW");
		} else {
			//RTA2N0R
			SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_StartPreview, CombineJsonContext("HSPS_VIEW_SHOW"));
			SetLastUserCode(GetAlarmDEC());
		}
	} else if (ISSUCCEEDED(erroCode)) {
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("Start to SetPreview(1)...");
		ullStart = SP::Module::Comm::RVCGetTickCount();
		erroCode = m_hDevHelper->SetPreview(1);
		ullEnd = SP::Module::Comm::RVCGetTickCount();
		if (FAILURED(erroCode)) {
			//RTA2N03
			SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetPreview_Open, "DevAdapter::SetPreview", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_StartPreview, CombineJsonContext("StartPreview::SetPreview(1)"));
			SetLastUserCode(GetAlarmDEC());
		} else {
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_StartPreview).setAPI("DevAdapter::SetPreview").setCostTime(ullEnd - ullStart)("StartPreview::SetPreview(1)");
		}
	} else {
		//RTA2N09
		SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_GetDevStatus, "DevAdapter::GetDevStatus", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_StartPreview, CombineJsonContext("GetDevStatus"));
		SetLastUserCode(GetAlarmDEC());
	}

	if (FAILURED(erroCode)) {
		nRes = 1;
	} else {
		LogEvent(Severity_Middle, LOG_EVT_HSPS_LIGHT_ON, "HSPScanner warning on.");
	}
	ctx->Answer(TransECWithRepeat(erroCode), GetLastUserCode());
	return nRes;
}

int CHSPScannerFSM::StopPreview(SpReqAnsContext<HSPScannerService_CancelPreview_Req,
	HSPScannerService_CancelPreview_Ans>::Pointer ctx)
{
	ErrorCodeEnum erroCode = Error_Unexpect;
	int nRes = 0;
	if (ctx->Req.bOnlyHide) {
		const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
		const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
		if (ISSUCCEEDED(erroCode)) {
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_CancelPreview).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)("HSPS_VIEW_HIDE");
			nRes = 1;
		} else {
			//RTA2N0Q
			SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_CancelPreview, CombineJsonContext("HSPS_VIEW_HIDE"));
			SetLastUserCode(GetAlarmDEC());
			nRes = 4;
		}
	}
	else
	{
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_USER)("Start to SetPreview(0).");
		const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
		erroCode = m_hDevHelper->SetPreview(0);
		const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
		if (ISSUCCEEDED(erroCode)) {
			nRes = 2;
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_CancelPreview).setAPI("DevAdapter::CancelPreview").setCostTime(ullEnd - ullStart)("SetPreview(0) succ");
			///*TODO:  (80374374@2/20/2024)*/
			LogWarn(Severity_Low, Error_Debug, LOG_EVT_HSPSCANNER_SetPreview_Close, "cancelPreview succ.");
		} else {
			//RTA2N04
			SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetPreview_Close, "DevAdapter::CancelPreview", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_CancelPreview, CombineJsonContext("SetPreview(0)"));
			SetLastUserCode(GetAlarmDEC());
		}
	}
	if (ISSUCCEEDED(erroCode)) {
		LogEvent(Severity_Middle, LOG_EVT_HSPS_LIGHT_OFF, "HSPScanner warning off.");
	}
	ctx->Answer(TransECWithRepeat(erroCode), GetLastUserCode());
	return nRes;
}

bool CHSPScannerFSM::ResizeImage(const CSimpleStringA& fileName)
{
	double rate; //limit rate
	int width;
	int height;
	bool success = TRUE;

	const int imageSize = m_dwMaxImageSize * 1024;

	FILE* fHandle = fopen(fileName.GetData(), "rb");
	if (!fHandle) {
		LogWarn(Severity_Middle, Error_Unexpect, LOG_WARN_HSPS_RESIZE_IMAGE_FILE_FAILED
			, CSimpleStringA::Format("fopen image %s for resize failed: %d", fileName.GetData(), errno));
		return FALSE;
	}

	fseek(fHandle, 0, SEEK_END);
	long fileSize = ftell(fHandle);
	fclose(fHandle);
	if (fileSize <= (imageSize)) {
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("File(%s)(%u<=%u) no need resize.", (LPCTSTR)fileName, fileSize, imageSize);
		return TRUE;
	}

	CSimpleStringA backUpFile, backUpPath;
    m_pEntity->GetFunction()->GetPath("Temp", backUpPath);
	backUpFile = backUpPath + SPLIT_SLASH_STR + "backupHSPSCannerImage";
	DeleteFileIfExisted(backUpFile);
#ifndef _WIN32
	fileutil_copy_file((LPCTSTR)backUpFile, (LPCTSTR)fileName);
#else
	CopyFileA(fileName, backUpFile, FALSE);
#endif //NOT _WIN32

	while (fileSize > imageSize)
	{
		rate = (double)fileSize / imageSize; 
		rate = 1.0 / sqrt(rate); //width and height limit rate
		cv::Mat img = cv::imread(fileName.GetData());
		if (!img.data) {
			LogWarn(Severity_Middle, Error_Unexpect, LOG_WARN_HSPS_OPENCV_READ_FAILED, "Opencv READ failed!");
			success = FALSE;
			break;
		}
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_USER)("to resize %lf rate...", rate);
		width = img.cols;
		height = img.rows;
		cv::resize(img, img, cv::Size(width * rate, height * rate));
		const bool openwrite = cv::imwrite(fileName.GetData(), img);
		if (!openwrite) {
			LogWarn(Severity_Middle, Error_Unexpect, LOG_WARN_HSPS_OPENCV_WRITE_FAILED, "Opencv WRITE failed!");
			success = FALSE;
			break;
		}

		fHandle = fopen(fileName.GetData(), "rb");
		fseek(fHandle, 0, SEEK_END);
		fileSize = ftell(fHandle);
		fclose(fHandle);
		Sleep(2);
	}

	if (!success) {
#ifndef _WIN32
		///*TODO(80374374@3/3/2023):  */
		fileutil_copy_file((LPCTSTR)fileName, (LPCTSTR)backUpFile); //recover original img
#endif //NOT _WIN32
		CopyFileA(backUpFile, fileName, FALSE);
		DeleteFileIfExisted(backUpFile);
		return FALSE;
	}
	fileSize = fileSize / 1024;
	DeleteFileIfExisted(backUpFile);
	LogWarn(Severity_Low, Error_Unexpect, LOG_WARN_HSPS_RESIZE_FUNCTION_SUCCEED,
		CSimpleStringA::Format("HSPScanner resize image succeed, SIZE : %d KB.", fileSize));
	return TRUE;
}

int CHSPScannerFSM::ScanImage(SpReqAnsContext<HSPScannerService_ScanImage_Req, 
	HSPScannerService_ScanImage_Ans>::Pointer ctx)
{
	int nRes = 0;
	ErrorCodeEnum erroCode = Error_Unexpect;
	CSimpleStringA csImageFile;
	GetCurImageName(csImageFile);
	BOOL bRet = DelAndGetNewFileName(csImageFile);
	if (!bRet) {
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImage).setResultCode(MapCode2RTAString(HSPScanner_UserErrorCode_CLEAR_RESOURCE_FAILED))("Cleare previous image failed before ScanImage");
		ctx->Answer(TransECWithRepeat(Error_Resource), HSPScanner_UserErrorCode_CLEAR_RESOURCE_FAILED);
		return 1;
	}
	///*TODO:  (80374374@2/20/2024)*/
	LogWarn(Severity_Low, Error_Debug, LOG_DEBUG_HSPS_CRITICAL_OPERATION_SCANIMAGE_START, "to ScanImage...");
	ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
	erroCode = m_hDevHelper->ScanImage((LPCTSTR)csImageFile);
	ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
	if (ISSUCCEEDED(erroCode)) {
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::ScanImage").setCostTime(ullEnd - ullStart)("DevAdapter::ScanImage succ");
		///*TODO:  (80374374@2/20/2024)*/
		LogWarn(Severity_Low, Error_Debug, LOG_DEBUG_HSPS_CRITICAL_OPERATION_SCANIMAGE_SUCC, "ScanImage succ");
		if (!ResizeImage(csImageFile)) {
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setResultCode("RTA2N0N").setAPI(__FUNCTION__)("HSPScanner resize image failed");
		}
		ctx->Ans.filePath = csImageFile;
		CBlob& cbData = ctx->Ans.imageData;
		FILE* fHandle = fopen(csImageFile, "rb");
		if (fHandle) {
			fseek(fHandle, 0, SEEK_END);
			long fileSize = ftell(fHandle);
			if (fileSize <= 0) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImage).setResultCode("RTA2N0S")("ftell(%s) error after invoking scanimage: %ld.", (LPCTSTR)csImageFile, fileSize);
				erroCode = Error_NotExist;
				fclose(fHandle);
				nRes = 4;
			} else {
				cbData.Alloc(fileSize);
				fseek(fHandle, 0, SEEK_SET);
				fread(cbData.m_pData, 1, fileSize, fHandle);
				fclose(fHandle);
			}
		} else {
			erroCode = Error_Resource;
			const int lasterr = errno;
			LogWarn(Severity_Middle, Error_Resource, HSPScanner_UserErrorCode_READ_IMAGE_FILE_FAILED, CSimpleStringA::Format("fopen(%s) failed after invoking scanimage: %d", (LPCTSTR)csImageFile, lasterr));
			SetLastUserCode(HSPScanner_UserErrorCode_READ_IMAGE_FILE_FAILED);
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImage).setResultCode("RTA2N0S")("fopen(%s) failed  after invoking scanimage: %d", (LPCTSTR)csImageFile, lasterr);
			nRes = 4;
		}
		if (ISSUCCEEDED(erroCode)) {
			// Additional ChangeTo Hide --Josephus at 11:32:29 2016/11/22
			if (true/*TODO: */) {
				ullStart = SP::Module::Comm::RVCGetTickCount();
				ErrorCodeEnum eHide = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
				ullEnd = SP::Module::Comm::RVCGetTickCount();
				if (ISSUCCEEDED(eHide)) {
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)("Hide Preview Dialog");
					nRes = 6;
				} else {
					//RTA2N0Q
					SetErrorAndLog(eHide, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_ScanImage, CombineJsonContext("HSPS_VIEW_HIDE"));
				}
			}

			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ScanImage).setAPI(__FUNCTION__)("ScanImage succ");
		}
		ctx->Answer(TransECWithRepeat(erroCode), GetLastUserCode());
	} else {
		SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_ScanImage, "DevAdapter::ScanImage", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_ScanImage);
		SetLastUserCode(GetAlarmDEC());
		ctx->Answer(TransECWithRepeat(erroCode), GetLastUserCode());
		nRes = 2;
	}
	return nRes;
}

int CHSPScannerFSM::ScanImageEx(SpReqAnsContext<HSPScannerService_ScanImageEx_Req, 
	HSPScannerService_ScanImageEx_Ans>::Pointer ctx)
{
	int nRes = 0;
	ErrorCodeEnum erroCode = Error_Unexpect;
	CSimpleStringA csImageFile;
	GetCurImageName(csImageFile, true);
	BOOL bRet = DelAndGetNewFileName(csImageFile);
	if (!bRet) {
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setResultCode(MapCode2RTAString(HSPScanner_UserErrorCode_CLEAR_RESOURCE_FAILED))("Cleare previous image failed before ScanImageEx");
		ctx->Answer(TransECWithRepeat(Error_Resource), HSPScanner_UserErrorCode_CLEAR_RESOURCE_FAILED);
		return 1;
	}

	int len = 0;
	BYTE* pBtImage = NULL;
	LogWarn(Severity_Low, Error_Debug, LOG_DEBUG_HSPS_CRITICAL_OPERATION_SCANIMAGEEX_START, "to ScanImageEx...");
	ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
	erroCode = m_hDevHelper->ScanImageEx(pBtImage, len, (LPCTSTR)csImageFile);
	ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
	if(erroCode == Error_TooSmallBuffer) {
		if (pBtImage) {
			delete pBtImage;
			pBtImage = NULL;
		}

		len += MAX_IMAGEDATA_SUFFIX;
		pBtImage = new BYTE[len+1];
		if (pBtImage == NULL) {
			DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setLogCode(HSPScannerService_LogCode_ScanImageEx).setResultCode("RTA2N0T")("new buffer[%d] failed %d.", len + 1, GetLastError());
			ctx->Answer(Error_Resource);
			return 3;
		}
		memset((void*)pBtImage, 0, len+1);
		ullStart = SP::Module::Comm::RVCGetTickCount();
		erroCode = m_hDevHelper->ScanImageEx(pBtImage, len, (LPCTSTR)csImageFile);
		ullEnd = SP::Module::Comm::RVCGetTickCount();
		if (erroCode == Error_Succeed) {
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::ScanImageEx").setCostTime(ullEnd - ullStart)("ScanImageEx suc %d, %d.", len, strlen((const char*)pBtImage));
		}
	}
	if (ISSUCCEEDED(erroCode)) {
		LogWarn(Severity_Low, Error_Debug, LOG_DEBUG_HSPS_CRITICAL_OPERATION_SCANIMAGEEX_SUCC, CSimpleStringA::Format("ScanImageEx suc %d, %d.", len, strlen((const char*)pBtImage)));
		if (ResizeImage(csImageFile)) {
			FILE* fHandle = fopen(csImageFile.GetData(), "rb");
			fseek(fHandle, 0, SEEK_END);
			len = ftell(fHandle);

			fseek(fHandle, 0, SEEK_SET);
			if (pBtImage) delete[] pBtImage;
			pBtImage = new BYTE[len];
			fread(pBtImage, 1, len, fHandle);
			fclose(fHandle);
		} else {
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setResultCode("RTA2N0N").setAPI(__FUNCTION__)("HSPScanner resize image failed");
		}
		ctx->Ans.filePath = csImageFile;
		CBlob& cbData = ctx->Ans.imageData;

		cbData.Alloc((len + 1) * sizeof(BYTE));
		memcpy_s(cbData.m_pData, cbData.m_iLength, pBtImage, len);
		cbData.Resize(len);

		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("ScanImageEx ctx: %s, %d.", (LPCTSTR)ctx->Ans.filePath, ctx->Ans.imageData.m_iLength);
		// Additional ChangeTo Hide --Josephus at 11:29:03 2016/11/22
		if (ISSUCCEEDED(erroCode)) {
			ullStart = SP::Module::Comm::RVCGetTickCount();
			ErrorCodeEnum eHide = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
			ullEnd = SP::Module::Comm::RVCGetTickCount();
			if (ISSUCCEEDED(eHide)) {
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)("Hide Preview Dialog");
				nRes = 6;
			} else {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart).setResultCode("RTA2N0Q")("Hide Preview Dialog failed: %s", SpStrError(eHide));
			}
			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);
		}
		ctx->Answer(TransECWithRepeat(erroCode));
	} else {
		//RTA2N06
		SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_ScanImageEx, "DevAdapter::ScanImageEx", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_ScanImageEx);
		SetLastUserCode(GetAlarmDEC());
		ctx->Answer(TransECWithRepeat(erroCode), GetLastUserCode());
		nRes = 2;
		}

	if (pBtImage) {
		delete pBtImage;
		pBtImage = NULL;
	}
	return nRes;
}

int CHSPScannerFSM::ShowProperty(SpReqAnsContext<HSPScannerService_ShowProperty_Req,
	HSPScannerService_ShowProperty_Ans>::Pointer ctx)
{
	ErrorCodeEnum erroCode = Error_Succeed;
	// Return ahead. [Josephus in 15:24:15 2016/11/21]
	const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
	ErrorCodeEnum ePos = m_hDevHelper->SetViewPos(730, 100, 540);
	const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
	if (FAILURED(ePos)) {
		//RTA2N07
		SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetViewPos, "DevAdapter::SetViewPos", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_ShowProperty);
	} else {
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_ShowProperty).setAPI("DevAdapter::SetViewPos").setCostTime(ullEnd - ullStart)();
	}
	ctx->Answer(TransECWithRepeat(erroCode));
	
	DWORD dwStart = GetTickCount();
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Start to show Property dialog...");
	erroCode = m_hDevHelper->SetProperty();
	DWORD dwEnd = GetTickCount();
	if (FAILURED(erroCode)) {
		//RTA2N0U
		SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetProperty, "DevAdapter::SetProperty", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_ShowProperty);
	} else {
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetProperty").setCostTime(dwEnd - dwStart)();
		erroCode = m_hDevHelper->SetViewPos(m_nRecX, m_nRecY, m_nRecW);
	}
	return 0;
}

int CHSPScannerFSM::SetProperty(SpReqAnsContext<HSPScannerService_SetProperty_Req, 
	HSPScannerService_SetProperty_Ans>::Pointer ctx)
{
	int nRes = 0;
	ErrorCodeEnum erroCode = Error_Succeed;
	int retCode = SetPreviewParam(ctx->Req.colorType, ctx->Req.rotateType, ctx->Req.scanType);
	if (retCode != 0) {
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_SetProperty).setResultCode(MapCode2RTAString(GetLastUserCode()))("SetParam failed retCode: 0x%X", retCode);
	} else {
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_SetProperty)("Set Property succ.");
	}
	ctx->Ans.retCode = retCode;
	ctx->Answer(Error_Succeed);
	return nRes;
}

int CHSPScannerFSM::SetWinPos(SpReqAnsContext<HSPScannerService_SetWinPos_Req, 
	HSPScannerService_SetWinPos_Ans>::Pointer ctx)
{
	int nRes = 0;
	ErrorCodeEnum erroCode = Error_Unexpect;
	ParamTypeValue value = HSPS_VIEW_SHOW;
	bool bSetCustom = false;
	switch (ctx->Req.type) {
	case 0: value = HSPS_VIEW_HIDE; break;
	case 1: value = HSPS_VIEW_SHOW; break;
	case 2: bSetCustom = true; break;
	default:
	{
		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);
		ctx->Answer(Error_Param, HSPScanner_UserErrorCode_NOT_SUPPORT);
		return nRes = 3;
	}
	break;
	}
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_USER)("SetWinPos: %s(%d).", ParamValToString(value), value);

	if (bSetCustom) {
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_USER)("Start to SetViewPos x(%d), y(%d), w(%d), reserved(%d).",
			ctx->Req.pointX, ctx->Req.pointY, ctx->Req.nWidth, ctx->Req.reserved4);
		const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
		erroCode = m_hDevHelper->SetViewPos(ctx->Req.pointX, ctx->Req.pointY, ctx->Req.nWidth);
		const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
		if (ISSUCCEEDED(erroCode)) {
			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);
			m_nRecX = ctx->Req.pointX;
			m_nRecY = ctx->Req.pointY;
			m_nRecW = ctx->Req.nWidth;
		} else {
			//RTA2N07
			SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetViewPos, "DevAdapter::SetViewPos", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_SetWinPos);
			SetLastUserCode(GetAlarmDEC());
			nRes = 2;
		}
	} else {
		const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, value);
		const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
		if (ISSUCCEEDED(erroCode)) {
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)("%d", value);
		} else {
			//RTA2N02
			SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_SetWinPos);
			SetLastUserCode(GetAlarmDEC());
			nRes = 1;
		}
	}
	if (ISSUCCEEDED(erroCode)) {
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_SetWinPos)("SetWinPos succ.");
	}
	ctx->Answer(TransECWithRepeat(erroCode), GetLastUserCode());
	return nRes;
}

int CHSPScannerFSM::GetDevStatus(SpReqAnsContext<HSPScannerService_GetDevStatus_Req, 
	HSPScannerService_GetDevStatus_Ans>::Pointer ctx)
{
	int nRes = 0;
	HspsDevStatus status = {0};
	const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
	ErrorCodeEnum erroCode = m_hDevHelper->GetDevStatus(status);
	const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
	if (ISSUCCEEDED(erroCode)) {
		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);
		ctx->Ans.connected = status.isConnected;
		ctx->Ans.previewing = status.inPreview;
		ctx->Ans.showing = status.inShow;
	} else {
		//RTA2N09
		SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_GetDevStatus, "DevAdapter::GetDevStatus", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_GetDevStatus);
		SetLastUserCode(GetAlarmDEC());
		nRes = 1;
	}
	ctx->Answer(TransECWithRepeat(erroCode), GetLastUserCode());
	return nRes;
}

int CHSPScannerFSM::GetDevInfo(SpReqAnsContext<HSPScannerService_GetDevInfo_Req, 
	HSPScannerService_GetDevInfo_Ans>::Pointer ctx)
{
	int nRes = 0;
	if (m_bOpening) {
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevInfo).setAPI(__FUNCTION__)("device is opening");
		ctx->Answer(Error_NotInit);
		nRes = 1;
	
	} else if (!m_bOpened) {
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(HSPScannerService_LogCode_GetDevInfo).setAPI(__FUNCTION__).setResultCode(MapCode2RTAString(GetLastUserCode()))("高拍仪设备未打开");
		ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
		nRes = 1;

	} else {
		DevCategoryInfo info = { 0 };
		const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
		ErrorCodeEnum erroCode = m_hDevHelper->GetDevCategory(info);
		const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
		ctx->Ans.state = (int)erroCode;
		if (ISSUCCEEDED(erroCode)) {
			ctx->Ans.model = info.szModel;
			ctx->Ans.type = info.szType;
			ctx->Ans.version = CSimpleStringA::Format("%d.%d.%d.%d",
				info.version.wMajor, info.version.wMinor, info.version.wRevision, info.version.wBuild);
			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"
				, ctx->Ans.model.GetData(), ctx->Ans.state, ctx->Ans.type.GetData(), ctx->Ans.version.GetData());
		}
		else {
			SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_GetDevCategory, "DevAdapter::GetDevCategory", __FUNCTION__, IsInBusiness(), ullEnd - ullStart, HSPScannerService_LogCode_GetDevInfo);
			SetLastUserCode(GetAlarmDEC());
			nRes = 1;
		}
		ctx->Answer(Error_Succeed);
	}
	return nRes;
}

BOOL CHSPScannerFSM::GetCurImageName(CSimpleStringA& csImagName, bool bExt /*= false*/)
{
    if (bExt) {
        csImagName = "MaterialImageExt.jpg";
    } else {
        csImagName = "MaterialImage.jpg";
    }
    return TRUE;
}

BOOL CHSPScannerFSM::DelAndGetNewFileName(CSimpleStringA& csfileName, bool bInBusiness)
{
	char fileName[MAX_PATH_SIZE] = {0};
	memset(fileName, 0, sizeof(char)*MAX_PATH_SIZE);
	strcpy_s(fileName, MAX_PATH_SIZE, (LPCTSTR)csfileName);
	if (strlen(fileName) == 0 || strchr(fileName, (int)'*') != NULL) {
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("Error input param");
		return FALSE;
	}
	CSimpleStringA strPath, strAimPath;
	m_pEntity->GetFunction()->GetPath("Dep", strPath);
	strAimPath = strPath + SPLIT_SLASH_STR + fileName;

	UpdateAndWarnFileFindInDepBak(strAimPath, fileName, HSPScanner_UserErrorCode_FindFile_in_DepBak);
#if 0
	///*TODO(80374374@10/11/2022): 这段代码上线一段时间后要去除，因为从这个版本开始这个文件就不生成在这个目录了 */
	if (ExistsFileA(strAimPath)) {
		if (DeleteFileA((LPCTSTR)strAimPath) != 0) {
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("DeleteFile(%s) suc.", (LPCTSTR)strAimPath);
		} else {
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("DeleteFile(%s) failed LastError(%d).", (LPCTSTR)strAimPath, GetLastError());
		}
	}
	strPath.Clear();
	GetEntityBase()->GetFunction()->GetPath("Temp", strPath);
	strAimPath = strPath + SPLIT_SLASH_STR + fileName;
#endif
	// Add [Josephus in 17:04:27 2016/10/25]
	csfileName = strAimPath;

	if (ExistsFileA(csfileName)) {
		if (RemoveFileA((LPCTSTR)strAimPath) != 0) {
			DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("DeleteFile(%s) suc.", (LPCTSTR)strAimPath);
			return TRUE;
		} else {
			if (bInBusiness) {
				DWORD  lastErr = GetLastError();
				if (lastErr == 5) {
					Sleep(100);
					if (!ExistsFileA(csfileName) || RemoveFileA((LPCTSTR)strAimPath) != 0) {
						DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("DeleteFile(%s) suc.", (LPCTSTR)strAimPath);
						return TRUE;
					}
					lastErr = GetLastError();
				} 
				LogError(Severity_Middle, Error_Unexpect, HSPScanner_UserErrorCode_CLEAR_RESOURCE_FAILED, CSimpleStringA::Format(
					"DeleteFile(%s)  failed before ScanImage, LastError(%d).", (LPCTSTR)strAimPath, lastErr));
			} else {
				LogWarn(Severity_High, Error_Unexpect, HSPScanner_UserErrorCode_CLEAR_RESOURCE_FAILED, CSimpleStringA::Format(
					"DeleteFile(%s) failed, LastError(%d).", (LPCTSTR)strAimPath, GetLastError()));
			}
			return FALSE;
		}
	} else {
		return TRUE;
	}
}

ErrorCodeEnum CHSPScannerFSM::OnDevExit()
{
	LOG_FUNCTION();
	ErrorCodeEnum erroCode = Error_Succeed;
	if(m_hDevHelper)
	{
		HspsDevStatus status = {0};
		ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
		erroCode = m_hDevHelper->GetDevStatus(status);
		ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
		if (erroCode == Error_Succeed) {
			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);
		} else {
			//RTA2N09
			SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_GetDevStatus, "DevAdapter::GetDevStatus", __FUNCTION__, false, ullEnd - ullStart);
		}

		if(ISSUCCEEDED(erroCode) && status.isConnected)
		{
			if (status.inPreview) {
				DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Invoke cancelPreview...");
				ullStart = SP::Module::Comm::RVCGetTickCount();
				erroCode = m_hDevHelper->SetPreview(0);
				ullEnd = SP::Module::Comm::RVCGetTickCount();
				if (ISSUCCEEDED(erroCode)) {
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setLogCode(__FUNCTION__).setAPI("DevAdapter::CancelPreview").setCostTime(ullEnd - ullStart)();
					LogEvent(Severity_Middle, LOG_EVT_HSPS_LIGHT_OFF, "HSPScanner warning off.");
					///*TODO:  (80374374@2/20/2024)*/
					LogWarn(Severity_Low, Error_Debug, LOG_EVT_HSPSCANNER_SetPreview_Close, "cancelPreview succ.");
				} else {
					//RTA2N04
					SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetPreview_Close, "DevAdapter::CancelPreview", __FUNCTION__, false, ullEnd - ullStart, "", CombineJsonContext("OnDevExit::SetPreview(0)"));
				}
			}
		} else if(ISSUCCEEDED(erroCode) && !status.isConnected){
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("HSPSCanner device is disconnected!");
		}
	}

	CSimpleStringA strNoUsed(true);
	GetCurImageName(strNoUsed);
	DelAndGetNewFileName(strNoUsed);
	GetCurImageName(strNoUsed, true);
	DelAndGetNewFileName(strNoUsed);

	return erroCode;
}

void CHSPScannerFSM::SelfTest(EntityTestEnum eTestType,
	CSmartPointer<ITransactionContext> pTransactionContext)
{
	static int openFailedCount = 0;
	if (GetCurrState()->id == CHSPScannerFSM::s3) {
		if (!m_bOpened && !m_bOpening) {

            if (!(bool)m_hDevHelper) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("hsps is not opened, , let selftest to restart it!");
                pTransactionContext->SendAnswer(Error_InvalidState);
                return;
            }

			openFailedCount++;
			if (openFailedCount > 3) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("try to open device exceed limited times, let selftest to restart it! %d", openFailedCount);
				pTransactionContext->SendAnswer(Error_InvalidState);
				return;
			} 
			OpenDeviceTask* pTask = new OpenDeviceTask(this);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
		} else if (m_bOpened && openFailedCount != 0) {
			openFailedCount = 0;
		}
	}
	if (m_ecSelfTest != Error_Succeed) {
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("selftest returned %s", SpStrError(m_ecSelfTest));
	}
	pTransactionContext->SendAnswer(m_ecSelfTest);
}

void CHSPScannerFSM::OnStateTrans(int iSrcState, int iDstState) 
{
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("trans from %s to %s", GetStateName(iSrcState), GetStateName(iDstState));
	m_nSrcState = iSrcState;
}

int CHSPScannerFSM::SetPreviewParam(int colorType, int rotateType, int scanType, bool abortIfFault)
{
	ErrorCodeEnum erroCode;
	int retCode = 0;
	if (colorType > 0 && colorType < 4) {
		const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_COLOR, Param_Color_Map[colorType]);
		const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
		if (ISSUCCEEDED(erroCode)) {
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)(ParamValToString(Param_Color_Map[colorType]));
		}
		else {
			SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, abortIfFault ? IsInBusiness() : false, ullEnd - ullStart, HSPScannerService_LogCode_SetProperty, CombineJsonContext(ParamValToString(Param_Color_Map[colorType])));
			retCode |= 0x0001;
			SetLastUserCode(GetAlarmDEC(MEC_DEVAPI_HSPSCANNER_SetParam));
		}
	}
	//////////////////////////////////////////////////////////////////////////
	if (rotateType > 0 && rotateType < 5) {
		const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_ROTATE, Param_Rotate_Map[rotateType]);
		const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
		if (ISSUCCEEDED(erroCode)) {
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)(ParamValToString(Param_Rotate_Map[rotateType]));
		}
		else {
			SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, abortIfFault ? IsInBusiness() : false, ullEnd - ullStart, HSPScannerService_LogCode_SetProperty, CombineJsonContext(ParamValToString(Param_Rotate_Map[rotateType])));
			retCode |= 0x0002;
			SetLastUserCode(GetAlarmDEC(MEC_DEVAPI_HSPSCANNER_SetParam));
		}
	}
	//////////////////////////////////////////////////////////////////////////
	if (scanType > 0 && scanType < 4) {
		const ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_SCANSIZE, Param_Scan_Map[scanType]);
		const ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
		if (ISSUCCEEDED(erroCode)) {
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("DevAdapter::SetParam").setCostTime(ullEnd - ullStart)(ParamValToString(Param_Scan_Map[scanType]));
		}
		else {
			SetErrorAndLog(erroCode, MEC_DEVAPI_HSPSCANNER_SetParam, "DevAdapter::SetParam", __FUNCTION__, abortIfFault ? IsInBusiness() : false, ullEnd - ullStart, HSPScannerService_LogCode_SetProperty, CombineJsonContext(ParamValToString(Param_Scan_Map[scanType])));
			retCode |= 0x0004;
			SetLastUserCode(GetAlarmDEC(MEC_DEVAPI_HSPSCANNER_SetParam));
		}
	}
	return retCode;
}

ErrorCodeEnum CHSPScannerFSM::DeleteFileIfExisted(LPCTSTR fileName)
{
	if (ExistsFileA(fileName)) {
		if (RemoveFileA(fileName) != 0) {
			DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("DeleteFile(%s) suc.", fileName);
			return Error_Succeed;
		} else {
			LogWarn(Severity_High, Error_Unexpect, HSPScanner_UserErrorCode_CLEAR_RESOURCE_FAILED, CSimpleStringA::Format(
				"DeleteFile(%s) failed LastError(%d) at ResizeImage proc", fileName, GetLastError()));
			return Error_Unexpect;
		}
	} else {
		return Error_Succeed;
	}
}

void CHSPScannerFSM::InitialMaxResizeValue()
{
	CSmartPointer<IEntityFunction> spFunction = this->GetEntityBase()->GetFunction();
	CSmartPointer<IConfigInfo> spConfig;
	spFunction->OpenConfig(Config_CenterSetting, spConfig);
	int kb = 0;
	spConfig->ReadConfigValueInt(GetEntityBase()->GetEntityName(), "ImageMaxSize", kb);
	if (kb > 0) {
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("Get image max size from CS: %d", kb);
		m_dwMaxImageSize = kb;
		return;
	}
}

ErrorCodeEnum CHSPScannerFSM::TryToOpenDevice()
{
	ErrorCodeEnum result(Error_Succeed);
	ULONGLONG ullStart = SP::Module::Comm::RVCGetTickCount();
	result = m_hDevHelper->DevOpen();
	ULONGLONG ullEnd = SP::Module::Comm::RVCGetTickCount();
	m_bOpening = false;
	if (FAILURED(result)) {
		//RTA2N01
		SetErrorAndLog(result, MEC_DEVAPI_HSPSCANNER_DevOpen, "DevAdapter::DevOpen", __FUNCTION__, false, ullEnd - ullStart);
		SetLastUserCode(LOG_ERR_HSPS_DEVOPEN_FAILED);
	} else {
		m_bOpened = true;
		SetLastUserCode();
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("DevAdapter::DevOpen").setCostTime(ullEnd - ullStart)("Open HSPS succ");
		ullStart = SP::Module::Comm::RVCGetTickCount();
		result = FulfillAdapterDevCategory();
		ullEnd = SP::Module::Comm::RVCGetTickCount();
		if (result != Error_Succeed) {
			SetErrorAndLog(result, MEC_DEVAPI_HSPSCANNER_GetDevCategory, "DevAdapter::GetDevCategory", "FulfillAdapterDevCategory", false, ullEnd - ullStart);
		}
		m_nRecX = 0;
		m_nRecY = 224;
		m_nRecW = 1024;
		ErrorCodeEnum ecInit = m_hDevHelper->SetViewPos(m_nRecX, m_nRecY, m_nRecW);
		ErrorCodeEnum ecInitScan = m_hDevHelper->SetParam(HSPS_MODEL_SCANSIZE, HSPS_SCAN_FULL);
		ErrorCodeEnum ecInitRotate = m_hDevHelper->SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_NOANGLE);
		ErrorCodeEnum ecInitColor = m_hDevHelper->SetParam(HSPS_MODEL_COLOR, HSPS_COLOR_FULL);
		if (FAILURED(ecInit) || FAILURED(ecInitScan) || FAILURED(ecInitRotate) || FAILURED(ecInitColor)) {
			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));
		}
		m_eDevStatus = DEVICE_STATUS_NORMAL;
	}
	return result;
}