myvtm/Module/mod_HSPScanner/HSPScannerFSM.cpp

#include "stdafx.h"
#include "HSPScannerFSM.h"
#include "EventCode.h"
#include "HSPSCanner_UserErrorCode.h"
#include "GetDevInfoHelper.h"
#include "CommDevEntityErrorCode.h"
#include "fileutil.h"
#include <winpr/sysinfo.h>
#include "opencv.hpp"
#include <math.h>

#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


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_csDllName(""),
	m_csDllFullPath(""),
	m_csDevNo(""),
	m_csPort(""),
	m_csBuadrate(""),
	m_eDevStatus(DEVICE_STATUS_NOT_READY),
	m_desiredAction(USER_EVT_QUIT),
	m_bOpened(false),
	m_bOpening(false),
	m_contiErrTimes(0),
	dwLastUserCode(0),
	m_dwMaxImageSize(500)
{
	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;
	ZeroMemory(&m_adapterInfo, sizeof(m_adapterInfo));
}

CHSPScannerFSM::~CHSPScannerFSM(void)
{

}

ErrorCodeEnum CHSPScannerFSM::OnInit()
{
	LOG_FUNCTION();
	GET_DEV_ENTITY_BASE_POINTER()->InitializeVendorLogSwitch();
	ErrorCodeEnum erroCode = Error_Succeed;
    m_csDllFullPath.Clear();
    auto pEntity = GET_DEV_ENTITY_BASE_POINTER();
	CSystemStaticInfo sysInfo;
	m_csMachineType = "";
	GetEntityBase()->GetFunction()->GetSystemStaticInfo(sysInfo);
	m_csMachineType = sysInfo.strMachineType;
	
	InitialMaxResizeValue();
    auto result = pEntity->ExtractVendorLibFullPath(m_csDllFullPath);
	if (result == Error_NotConfig) {
        PostEventLIFO(new FSMEvent(USER_EVT_NOCFG));
        return Error_Succeed;
	}
	if(FAILURED(result)) {
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Fetch Vendor dllName failed %s.", (LPCTSTR)m_csDllFullPath);
		goto FAIL;
	}
	LogWarn(Severity_Low, Error_Unexpect, HSPScanner_UserErrorCode_ROOT_INFO, (LPCTSTR)m_csDllFullPath);
	m_adapterInfo.adapterFileName = m_csDllFullPath;
	m_csDllName = pEntity->GetVendorLibName();

	HARDWARE_ENTITY_SET_VENDOR_NAME(m_entCode, pEntity->vendorLibInfo.strVendor);
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("VendorDllName: %s.", (LPCTSTR)m_csDllFullPath);
    result = m_hDevHelper.LoadUp(m_csDllFullPath);
    if (result != Error_Succeed) {
#ifdef RVC_OS_WIN
        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("%s - GLE=%u", (LPCTSTR)pEntity->GetVendorLibName(), GetLastError());
#endif
	} else {
        if (Error_Succeed == (erroCode = TryToOpenDevice())) {
            m_eDevStatus = DEVICE_STATUS_NORMAL;
            return erroCode;
        }
	}

FAIL:

	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;

	if (m_FirstStart) {
		m_FirstStart = FALSE;
		ToLogRootINIInfo(this);
		ToLogWarnInfoAboutTerm(this, m_adapterInfo);
	}
}

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:
		{
			GetDevInfoTask* pTask = new GetDevInfoTask(this);
			GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
			pTask->SetContext(pEvt->m_ctx);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
		}
		e->SetHandled();
		break;
	case USER_EVT_NOCFG:
		{
			DbgWithLink(LOG_LEVEL_DEBUG, 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_INFO, LOG_TYPE_SYSTEM)("HSPScaner init failed!");
		break;
	default:
		{
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("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:
		{
			GetDevInfoTask* pTask = new GetDevInfoTask(this);
			GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
			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:
		{
			GetDevInfoTask* pTask = new GetDevInfoTask(this);
			GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
			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) {
				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};
				ErrorCodeEnum erroCode = m_hDevHelper->GetDevStatus(status);
				if(status.inPreview == 1)
				{
					StopPreviewTask* pTask = new StopPreviewTask(this);
					pTask->SetContext(pEvt->m_ctx);
					GetEntityBase()->GetFunction()->PostEntityTaskFIFO(pTask);
				}
				else if(status.inShow == 1)
				{
					erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
					pEvt->m_ctx->Answer((erroCode));
					FSMEvent* timerEvent = new FSMEvent(EVT_TIMER);
					timerEvent->param1 = RESET_TIMER_ID;
					PostEventFIFO(timerEvent);
				}
			} else if (!m_bOpened) {
				StopPreviewEvent* pEvt = dynamic_cast<StopPreviewEvent*>(e);
				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) {
			ErrorCodeEnum erroCode = m_hDevHelper->Reset();
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Reset operation returned %s.", SpStrError(erroCode));
			if(FAILURED(erroCode))
			{
				LOG_HSPSCANNER_ERROR_MSG_MACRO(erroCode, Reset);
				m_ecSelfTest = Error_InvalidState;
				uRet = 1;
			}
			else
			{
				ErrorCodeEnum eXYW = m_hDevHelper->SetViewPos(m_nRecX, m_nRecY, m_nRecW);
				if(FAILURED(eXYW))
				{
					LOG_HSPSCANNER_ERROR_MSG_MACRO(eXYW, SetViewPos);
					uRet = 1;
					m_ecSelfTest = Error_InvalidState;
					e->SetHandled();
					break;
				}
				HspsDevStatus status = {0};
				CSimpleStringA strFuncName(true);
				erroCode = m_hDevHelper->GetDevStatus(status);
				if(status.inPreview == 1 && status.inShow == 1)
				{
					if(m_desiredAction == USER_EVT_STOPPREVIEW)
					{
						erroCode = m_hDevHelper->SetPreview(0);
						strFuncName = "SetPreview";
						UpdateDEC(MEC_DEVAPI_HSPSCANNER_SetPreview_Close);
						{
							HspsDevStatus retryStatus = {0};
							m_hDevHelper->GetDevStatus(retryStatus);
							if(retryStatus.inPreview == 1) 
							{
								erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
								UpdateDEC(MEC_DEVAPI_HSPSCANNER_SetParam);
								strFuncName = "SetParam";
							}
						}
					}
					else if(m_desiredAction == USER_EVT_HIDEPREVIEW)
					{
						erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
						UpdateDEC(MEC_DEVAPI_HSPSCANNER_SetParam);
						strFuncName = "SetParam";
					}
					if(FAILURED(erroCode))
					{
					    DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Recover failed under desiration of %s", EvtTypeToString(m_desiredAction));
						LogErrMsg(strFuncName, erroCode, 0, TRUE);
						uRet = 1;
						m_ecSelfTest = Error_InvalidState;
						e->SetHandled();
						break;
					}
					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) {
				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) {
				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) {
            pEvt->m_ctx->Answer(Error_DevNotAvailable, GetLastUserCode());
			e->SetHandled();
		}
	}
    break;
	}
	return uRet;
}

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

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:
		{
			GetDevInfoTask* pTask = new GetDevInfoTask(this);
			GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
			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};
				ErrorCodeEnum eResult = m_hDevHelper->GetDevStatus(status);
				if(ISSUCCEEDED(eResult))
				{
					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;
					}
				}
				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:
		{
			GetDevInfoTask* pTask = new GetDevInfoTask(this);
			GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
			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()
{
	LOG_FUNCTION();
}

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:
		{
			GetDevInfoTask* pTask = new GetDevInfoTask(this);
			GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
			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};
		ErrorCodeEnum erroCode = m_hDevHelper->GetDevStatus(status);
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Get status(%d): Connected(%d), Preview(%d), Show(%d).",
			erroCode, status.isConnected, status.inPreview, status.inShow);
	}
}

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:
		{
			GetDevInfoTask* pTask = new GetDevInfoTask(this);
			GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
			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;
	if(e->iEvt == USER_EVT_GETINFO) {
		GetDevInfoEvent* pEvt = dynamic_cast<GetDevInfoEvent*>(e);
		pEvt->m_ctx->Ans.model = "";
		pEvt->m_ctx->Ans.state = DEVICE_STATUS_NOCFG;
		pEvt->m_ctx->Ans.type = "";
		pEvt->m_ctx->Ans.version = "";
		pEvt->m_ctx->Answer(Error_Succeed);
		e->SetHandled();

	} else {
		switch (e->iEvt) {
		case USER_EVT_STARTPREVIEW:
		{
			StartPreviewEvent* pEvt = dynamic_cast<StartPreviewEvent*>(e);
			pEvt->SetHandled();
			pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
		}
		break;
		case USER_EVT_STOPPREVIEW:
		{
			StopPreviewEvent* pEvt = dynamic_cast<StopPreviewEvent*>(e);
			pEvt->SetHandled();
			pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
		}
		break;
		case USER_EVT_SCANIMAGE:
		{
			ScanImageEvent* pEvt = dynamic_cast<ScanImageEvent*>(e);
			pEvt->SetHandled();
			pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
		}
		break;
		case USER_EVT_SCANIMAGE_EX:
		{
			ScanImageExEvent* pEvt = dynamic_cast<ScanImageExEvent*>(e);
			pEvt->SetHandled();
			pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
		}
		break;
		case USER_EVT_SHOWPROPERTY:
		{
			ShowPropertyEvent* pEvt = dynamic_cast<ShowPropertyEvent*>(e);
			pEvt->SetHandled();
			pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
		}
		break;
		case USER_EVT_SETPROPERTY:
		{
			SetPropertyEvent* pEvt = dynamic_cast<SetPropertyEvent*>(e);
			pEvt->SetHandled();
			pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
		}
		break;
		case USER_EVT_SETWINPOS:
		{
			SetWinPosEvent* pEvt = dynamic_cast<SetWinPosEvent*>(e);
			pEvt->SetHandled();
			pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
		}
		break;
		case USER_EVT_GETSTATUS:
		{
			GetDevStatusEvent* pEvt = dynamic_cast<GetDevStatusEvent*>(e);
			pEvt->SetHandled();
			pEvt->m_ctx->Answer(Error_InvalidState, GetLastUserCode());
		}
		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)
	{
		erroCode = SetPreview(ctx);
	}

	HspsDevStatus status = {0};
	erroCode = m_hDevHelper->GetDevStatus(status);
	if(ISSUCCEEDED(erroCode) && status.inPreview)
	{// 用于s6状态 [Josephus in 9:33:48 2016/11/22]
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_SHOW);
	}
	else if(ISSUCCEEDED(erroCode))
	{
        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Start to SetPreview(1).");
		const DWORD consdwBegin = GetTickCount();
		erroCode = m_hDevHelper->SetPreview(1);
		const DWORD consdwEnd = GetTickCount();
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("SetPreview")
							.setBeginTime(consdwBegin).setEndTime(consdwEnd)("End to SetPreview(1) returned %s.", SpStrError(erroCode));
		if(FAILURED(erroCode)) {
			SetErrPackage(m_errPkg, "StartPreview::SetPreview(1)", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_SetPreview_Open);
			SetLastUserCode(AlarmDEC(m_errPkg, true));
		}
	}
	else
	{
		SetErrPackage(m_errPkg, "StartPreview::GetDevStatus", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_GetDevStatus);
		SetLastUserCode(AlarmDEC(m_errPkg, true));
	}

	if(FAILURED(erroCode))
	{
		nRes = 1;
	}
	else
	{
		LogEvent(Severity_Middle, LOG_EVT_HSPS_LIGHT_ON, "HSPScanner warning on.");
	}
	ctx->Answer((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)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("End to SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE) returned %d(0x%x).", erroCode, erroCode);
		if(ISSUCCEEDED(erroCode))
		{
			nRes = 1;
		}
		else 
		{
			SetErrPackage(m_errPkg, "Hide Preview", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_SetParam);
			SetLastUserCode(AlarmDEC(m_errPkg, true));
			nRes = 4;
		}
	}
	else
	{
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_USER)("Start to SetPreview(0).");
		const DWORD consdwBegin = GetTickCount();
		erroCode = m_hDevHelper->SetPreview(0);
		const DWORD consdwEnd = GetTickCount();
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("SetPreview").setBeginTime(consdwBegin).setEndTime(consdwEnd)("End to SetPreview(0) reuturned %d(0x%x).", erroCode, erroCode);
		if(ISSUCCEEDED(erroCode))
		{
			nRes = 2;
		} else {
			SetErrPackage(m_errPkg, "StopPreview::SetPreview(0)", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_SetPreview_Close);
			SetLastUserCode(AlarmDEC(m_errPkg, true));
		}
	}
	if(ISSUCCEEDED(erroCode))
	{
		LogEvent(Severity_Middle, LOG_EVT_HSPS_LIGHT_OFF, "HSPScanner warning off.");
	}
	ctx->Answer((erroCode), GetLastUserCode());
	return nRes;
}

bool CHSPScannerFSM::ResizeImage(CSimpleStringA fileName)
{
	LOG_FUNCTION();

	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_EVT_HSPS_READ_IMAGE_FILE_FAILED
			, CSimpleStringA::Format("Read image %s failed: %d", fileName.GetData(), errno));
		return FALSE;
	}

	fseek(fHandle, 0, SEEK_END);
	long fileSize = ftell(fHandle);
	fclose(fHandle);
	if (fileSize <= (imageSize)) {
		DbgWithLink(LOG_LEVEL_WARN, 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);
	fileutil_copy_file((LPCTSTR)backUpFile, (LPCTSTR)fileName);

	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) {
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER)("Resize Image failed.");
		fileutil_copy_file((LPCTSTR)fileName, (LPCTSTR)backUpFile); //recover original img
		CopyFileA(backUpFile, fileName, FALSE);
		DeleteFileIfExisted(backUpFile);
		return FALSE;
	}

	fileSize = fileSize / 1024;

	DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("Resize Image suc.");
	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)
	{
		ctx->Answer((Error_Resource), HSPScanner_UserErrorCode_IMAGE_CLEAR);
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_USER)("Create imgPath failed.");
		return 1;
	}
	
	LogWarn(Severity_Low, Error_Debug, LOG_DEBUG_HSPS_CRITICAL_OPERATION_SCANIMAGE, "to ScanImage...");
	const DWORD consdwBegin = GetTickCount();
	erroCode = m_hDevHelper->ScanImage((LPCTSTR)csImageFile);
	const DWORD consdwEnd = GetTickCount();
	if(ISSUCCEEDED(erroCode))
	{
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setAPI("ScanImage").setBeginTime(consdwBegin).setEndTime(consdwEnd)("scan image succ.");
		LogWarn(Severity_Low, Error_Debug, LOG_DEBUG_HSPS_CRITICAL_OPERATION_SCANIMAGE, "ScanImage succ");

		if (!ResizeImage(csImageFile)) {
			LogWarn(Severity_Middle, Error_Unexpect, LOG_WARN_HSPS_RESIZE_IMAGE_FILE_FAILED, "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_ERROR, LOG_TYPE_USER)("filesize(%s) error: %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;
			LogError(Severity_High, Error_Resource, HSPScanner_UserErrorCode_READ_IMAGE_FILE_FAILED,
				CSimpleStringA::Format("fopen(%s) failed: %d, %s", (LPCTSTR)csImageFile, errno, strerror(errno))
			);
			SetLastUserCode(HSPScanner_UserErrorCode_READ_IMAGE_FILE_FAILED);
			nRes = 4;
		}
		if(ISSUCCEEDED(erroCode))
		{
			// Additional ChangeTo Hide --Josephus at 11:32:29 2016/11/22
			if(true/*TODO: */)
			{
				ErrorCodeEnum eHide = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE) returned %s", SpStrError(eHide));
				if(ISSUCCEEDED(eHide))
				{
					nRes = 6;
				}
			}
		}
		ctx->Answer((erroCode), GetLastUserCode());
	}
	else
	{
		SetErrPackage(m_errPkg, "ScanImage::ScanImage", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_ScanImage);
		SetLastUserCode(AlarmDEC(m_errPkg, true));
		ctx->Answer((erroCode), GetLastUserCode());
		return 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)
	{
		ctx->Answer((Error_Resource), HSPScanner_UserErrorCode_IMAGE_CLEAR);
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_USER)("Create imgPath failed.");
		return 1;
	}

#if 0
	int len = MAX_IMAGEDATA_BUFSIZE;
	BYTE* pBtImage = new BYTE[len+1];
	if(pBtImage == NULL)
	{
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("new buffer[%d] failed %d.", len+1, GetLastError());
		ctx->Answer(Error_Resource);
		return 3;
	}
	memset((void*)pBtImage, 0, len+1);
#else
	int len = 0;
	BYTE* pBtImage = NULL;
#endif

	LogWarn(Severity_Low, Error_Debug, LOG_DEBUG_HSPS_CRITICAL_OPERATION_SCANIMAGEEX, "to ScanImageEx...");

	int nOldLen = len;
	const DWORD consdwBegin = GetTickCount();
	erroCode = m_hDevHelper->ScanImageEx(pBtImage, len, (LPCTSTR)csImageFile);
	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_USER)("new buffer[%d] failed %d.", len+1, GetLastError());
			ctx->Answer(Error_Resource);
			return 3;
		}
		memset((void*)pBtImage, 0, len+1);
		erroCode = m_hDevHelper->ScanImageEx(pBtImage, len, (LPCTSTR)csImageFile);
	}
    const DWORD consdwEnd = GetTickCount();
	if(ISSUCCEEDED(erroCode))
	{
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setBeginTime(consdwBegin).setEndTime(consdwEnd)("ScanImageEx suc %d, %d.", len, strlen((const char*)pBtImage));
		LogWarn(Severity_Low, Error_Debug, LOG_DEBUG_HSPS_CRITICAL_OPERATION_SCANIMAGEEX, 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 {
			LogWarn(Severity_Middle, Error_Unexpect, LOG_WARN_HSPS_RESIZE_IMAGEEX_FILE_FAILED, "HSPScanner resize imageEX faild.");
		}

		ctx->Ans.filePath = csImageFile;
		CBlob& cbData = ctx->Ans.imageData;
		
#if 1
		cbData.Alloc((len+1)*sizeof(BYTE));
		memcpy_s(cbData.m_pData, cbData.m_iLength, pBtImage, len);
		cbData.Resize(len);
#else 
		FILE* fHandle = fopen(csImageFile, "rb");
		if(fHandle)
		{
			fseek(fHandle, 0, SEEK_END);
			long fileSize = ftell(fHandle);
			cbData.Alloc(fileSize);
			fseek(fHandle, 0, SEEK_SET);
			fread(cbData.m_pData, 1, fileSize, fHandle);
			fclose(fHandle);
		}
		else
		{
			LOG_TRACE("fopen(%s) failed.", (LPCTSTR)csImageFile);
			erroCode = Error_IO;
			GetAndDbgDevError();
			SetLastUserCode(HSPScanner_UserErrorCode_READ_IMAGE_FILE_FAILED);
			nRes = 4;
		}
#endif
		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))
		{
			ErrorCodeEnum eHide = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE);
			DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("SetParam(HSPS_MODEL_VIEW, HSPS_VIEW_HIDE) returned %s", SpStrError(eHide));
			if(ISSUCCEEDED(eHide))
			{
				nRes = 6;
			}
		}
		ctx->Answer((erroCode));
	}
	else
	{
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_USER)("ScanImageEx failed returned %s, %d, %d.", SpStrError(erroCode), len, strlen((const char*)pBtImage));
		SetErrPackage(m_errPkg, "ScanImageEx::ScanImageEx", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_ScanImageEx);
		SetLastUserCode(AlarmDEC(m_errPkg, true));
		ctx->Answer((erroCode), GetLastUserCode());
		nRes = 2;
	}

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

int CHSPScannerFSM::ShowProperty(SpReqAnsContext<HSPScannerService_ShowProperty_Req,
	HSPScannerService_ShowProperty_Ans>::Pointer ctx)
{
	int nRes = 0;
	ErrorCodeEnum erroCode = Error_Succeed;
	// Return ahead. [Josephus in 15:24:15 2016/11/21]
	ErrorCodeEnum ePos = m_hDevHelper->SetViewPos(730, 100, 540);
	ctx->Answer((erroCode));
	
	DWORD dwStart = GetTickCount();
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Start to show Property dialog...");
	erroCode = m_hDevHelper->SetProperty();
	DWORD dwEnd = GetTickCount();
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setBeginTime(dwStart).setEndTime(dwEnd)("End to show Property dialog! used: %ums.", dwEnd - dwStart);
	if(ISSUCCEEDED(ePos))
	{
		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 = 0;
	//////////////////////////////////////////////////////////////////////////
	if(ctx->Req.colorType == 1)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_COLOR, HSPS_COLOR_FULL);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_COLOR, HSPS_COLOR_FULL) returned %d.", erroCode);
	}
	else if(ctx->Req.colorType == 2)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_COLOR, HSPS_COLOR_GREY);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_COLOR, HSPS_COLOR_GREY) returned %d.", erroCode);
	}
	if(FAILURED(erroCode)) 
	{
		retCode |= 0x0001;
		//GetAndDbgDevError();
		SetErrPackage(m_errPkg, "SetProperty::SetParam", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_SetParam);
		SetLastUserCode(AlarmDEC(m_errPkg));
		erroCode = Error_Succeed;
	}
	//////////////////////////////////////////////////////////////////////////
	if(ctx->Req.rotateType == 1)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_NOANGLE);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_NOANGLE) returned %d.", erroCode);
	}
	else if(ctx->Req.rotateType == 2)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_LEFT);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_LEFT) returned %d.", erroCode);
	}
	else if(ctx->Req.rotateType == 3)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_MIRROR);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_MIRROR) returned %d.", erroCode);
	}
	else if(ctx->Req.rotateType == 4)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_RIGHT);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_RIGHT) returned %d.", erroCode);
	}
	if(FAILURED(erroCode)) 
	{
		retCode |= 0x0002;
		SetErrPackage(m_errPkg, "SetProperty::SetParam", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_SetParam);
		SetLastUserCode(AlarmDEC(m_errPkg));
		erroCode = Error_Succeed;
	}
	//////////////////////////////////////////////////////////////////////////
	if(ctx->Req.scanType == 1)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_SCANSIZE, HSPS_SCAN_FULL);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_SCANSIZE, HSPS_SCAN_FULL) returned %d.", erroCode);
	}
	else if(ctx->Req.scanType == 2)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_SCANSIZE, HSPS_SCAN_A4);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_SCANSIZE, HSPS_SCAN_A4) returned %d.", erroCode);
	}
	else if(ctx->Req.scanType == 3)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_SCANSIZE, HSPS_SCAN_IDCARD);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_SCANSIZE, HSPS_SCAN_IDCARD) returned %d.", erroCode);
	}
	if(FAILURED(erroCode)) 
	{
		retCode |= 0x0004;
		SetErrPackage(m_errPkg, "SetProperty::SetParam", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_SetParam);
		SetLastUserCode(AlarmDEC(m_errPkg));
		erroCode = Error_Succeed;
	}

	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)("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_INFO, 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);
		erroCode = m_hDevHelper->SetViewPos(ctx->Req.pointX, ctx->Req.pointY, ctx->Req.nWidth);
		if(FAILURED(erroCode))
		{
			SetErrPackage(m_errPkg, "SetWinPos::SetViewPos", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_SetViewPos);
			SetLastUserCode(AlarmDEC(m_errPkg));
			nRes = 2;
		}
		else
		{
			m_nRecX = ctx->Req.pointX;
			m_nRecY = ctx->Req.pointY;
			m_nRecW = ctx->Req.nWidth;
		}
	}
	else
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_VIEW, value);
		if(FAILURED(erroCode))
		{
			SetErrPackage(m_errPkg, "SetWinPos::SetParam", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_SetParam);
			SetLastUserCode(AlarmDEC(m_errPkg));
			nRes = 1;
		}
	}
	ctx->Answer((erroCode), GetLastUserCode());
	return nRes;
}

int CHSPScannerFSM::GetDevStatus(SpReqAnsContext<HSPScannerService_GetDevStatus_Req, 
	HSPScannerService_GetDevStatus_Ans>::Pointer ctx)
{
	int nRes = 0;
	HspsDevStatus status = {0};
	ErrorCodeEnum erroCode = m_hDevHelper->GetDevStatus(status);
	if(ISSUCCEEDED(erroCode))
	{
		ctx->Ans.connected = status.isConnected;
		ctx->Ans.previewing = status.inPreview;
		ctx->Ans.showing = status.inShow;
	}
	else
	{
		SetErrPackage(m_errPkg, "GetDevStatus::GetDevStatus", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_GetDevStatus);
		SetLastUserCode(AlarmDEC(m_errPkg));
		nRes = 1;
	}
	ctx->Answer((erroCode), GetLastUserCode());
	return nRes;
}

int CHSPScannerFSM::GetDevInfo(SpReqAnsContext<HSPScannerService_GetDevInfo_Req, 
	HSPScannerService_GetDevInfo_Ans>::Pointer ctx)
{
	int nRes = 0;
	DevCategoryInfo info = {0};
	ErrorCodeEnum erroCode = m_hDevHelper->GetDevCategory(info);
	if(ISSUCCEEDED(erroCode))
	{
		ctx->Ans.model = info.szModel;
		ctx->Ans.state = (int)info.eState;
		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);
	}
	else
	{
		SetErrPackage(m_errPkg, "GetDevInfo::GetDevCategory", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_GetDevCategory);
		SetLastUserCode(AlarmDEC(m_errPkg));
		nRes = 1;
	}
	{
		ctx->Ans.state = (int)m_eDevStatus;
	}
	ctx->Answer((erroCode), GetLastUserCode());
	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)
{
	LOG_FUNCTION();
	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)
	{
		return FALSE;
	}
	CSimpleStringA strPath, strAimPath;
	ErrorCodeEnum erroCode = m_pEntity->GetFunction()->GetPath("Dep", strPath);
	strAimPath = strPath + SPLIT_SLASH_STR + fileName;

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

	// Add [Josephus in 17:04:27 2016/10/25]
	csfileName = strAimPath;
	if (ExistsFileA(csfileName)) {
        if (RemoveFileA((LPCTSTR)strAimPath) != 0) {
            DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("DeleteFile(%s) suc.", (LPCTSTR)strAimPath);
            return TRUE;
        } 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;
	}
	DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("DeleteFile(%s) Unexpect GetLastError(%d).", (LPCTSTR)strAimPath, GetLastError());
	return FALSE;
}

ErrorCodeEnum CHSPScannerFSM::OnDevExit()
{
	LOG_FUNCTION();
	ErrorCodeEnum erroCode = Error_Succeed;
	if(m_hDevHelper)
	{
		HspsDevStatus status = {0};
		erroCode = m_hDevHelper->GetDevStatus(status);
		if(ISSUCCEEDED(erroCode) && status.isConnected)
		{
			if(status.inPreview)
			{
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Invoke cancelPreview...");
				erroCode = m_hDevHelper->SetPreview(0);
				DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Close Preview OnDevExit returned %s", SpStrError(erroCode));
				if(ISSUCCEEDED(erroCode)) {
					LogEvent(Severity_Middle, LOG_EVT_HSPS_LIGHT_OFF, "HSPScanner warning off.");
				} else {
					SetErrPackage(m_errPkg, "OnDevExit::SetPreview(0)", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_SetPreview_Close);
					AlarmDEC(m_errPkg);
				}
			}
		} else if (!FAILURED(erroCode)) {
			SetErrPackage(m_errPkg, "OnDevExit::GetDevStatus", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_GetDevStatus);
			AlarmDEC(m_errPkg);
		} else {
			DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("HSPSCanner device is disconnected!");
		}
	}

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

	return erroCode;
}

UINT CHSPScannerFSM::UnitTest(LPCTSTR testTag)
{
#ifdef TWINKLE_LOCAL_DEBUG
	LOG_FUNCTION();
	do
	{
		UploadVendorDllInfo();

	}while(false);

#endif //TWINKLE_LOCAL_DEBUG

	return 0;
}

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) {
                pTransactionContext->SendAnswer(Error_InvalidState);
                return;
            }

			openFailedCount++;
			if (openFailedCount > 3) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("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;
		}
	}
	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;
}

ErrorCodeEnum CHSPScannerFSM::SetPreview(SpReqAnsContext<HSPScannerService_StartPreview_Req,
	HSPScannerService_StartPreview_Ans>::Pointer ctx)
{
	int nRes = 0;
	ErrorCodeEnum erroCode = Error_Succeed;
	int retCode = 0;
	//////////////////////////////////////////////////////////////////////////
	if(ctx->Req.colorType == 1)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_COLOR, HSPS_COLOR_FULL);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_COLOR, HSPS_COLOR_FULL) returned %d.", erroCode);
	}
	else if(ctx->Req.colorType == 2)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_COLOR, HSPS_COLOR_GREY);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_COLOR, HSPS_COLOR_GREY) returned %d.", erroCode);
	}
	if(FAILURED(erroCode)) 
	{
		retCode |= 0x0001;
		SetErrPackage(m_errPkg, "SetPreview::SetParam", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_SetParam);
		SetLastUserCode(AlarmDEC(m_errPkg));
		erroCode = Error_Succeed;
	}
	//////////////////////////////////////////////////////////////////////////
	if(ctx->Req.rotateType == 1)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_NOANGLE);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_NOANGLE) returned %d.", erroCode);
	}
	else if(ctx->Req.rotateType == 2)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_LEFT);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_LEFT) returned %d.", erroCode);
	}
	else if(ctx->Req.rotateType == 3)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_MIRROR);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_MIRROR) returned %d.", erroCode);
	}
	else if(ctx->Req.rotateType == 4)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_RIGHT);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_ROTATE, HSPS_ROTATE_RIGHT) returned %d.", erroCode);
	}
	if(FAILURED(erroCode)) 
	{
		retCode |= 0x0002;
		SetErrPackage(m_errPkg, "SetPreview::SetParam", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_SetParam);
		SetLastUserCode(AlarmDEC(m_errPkg));
		erroCode = Error_Succeed;
	}
	//////////////////////////////////////////////////////////////////////////
	if(ctx->Req.scanType == 1)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_SCANSIZE, HSPS_SCAN_FULL);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_SCANSIZE, HSPS_SCAN_FULL) returned %d.", erroCode);
	}
	else if(ctx->Req.scanType == 2)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_SCANSIZE, HSPS_SCAN_A4);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_SCANSIZE, HSPS_SCAN_A4) returned %d.", erroCode);
	}
	else if(ctx->Req.scanType == 3)
	{
		erroCode = m_hDevHelper->SetParam(HSPS_MODEL_SCANSIZE, HSPS_SCAN_IDCARD);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER)("SetParam(HSPS_MODEL_SCANSIZE, HSPS_SCAN_IDCARD) returned %d.", erroCode);
	}
	if(FAILURED(erroCode)) 
	{
		retCode |= 0x0004;
		SetErrPackage(m_errPkg, "SetPreview::SetParam", m_csDevNo, erroCode, MEC_DEVAPI_HSPSCANNER_SetParam);
		SetLastUserCode(AlarmDEC(m_errPkg));
		erroCode = Error_Succeed;
	}

	ctx->Ans.retCode = retCode;
	ctx->Ans.reserved1 = 404040404;
	
	if(retCode == 0)
	{
		return Error_Succeed;
	}
	return Error_DevCommFailed;
}

ErrorCodeEnum CHSPScannerFSM::DeleteFileIfExisted(LPCTSTR fileName)
{
	ErrorCodeEnum erroCode = Error_Unexpect;
	if (ExistsFileA(fileName)) {
        if (RemoveFileA(fileName) != 0) {
            DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("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).", fileName, GetLastError()));
			return Error_Unexpect;
        }
	} else {
		return Error_Succeed;
	}
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("DeleteFile(%s) Unexpect GetLastError(%d).", fileName, GetLastError());
	return Error_Unexpect;
}

void CHSPScannerFSM::InitialMaxResizeValue()
{
	CSmartPointer<IEntityFunction> spFunction = this->GetEntityBase()->GetFunction();
	CSmartPointer<IConfigInfo> spConfig;
	ErrorCodeEnum erroCode = Error_Unexpect;
	spFunction->OpenConfig(Config_CenterSetting, spConfig);
	int kb = 0;
	spConfig->ReadConfigValueInt(GetEntityBase()->GetEntityName(), "ImageMaxSize", kb);
	if (kb > 0) {
		LogWarn(Severity_Low, Error_Unexpect, LOG_WARN_HSPS_READ_CONFIG_FILE_FAILED, CSimpleStringA::Format("Get image max size from CS: %d", kb));
		m_dwMaxImageSize = kb;
		return;
	}
}

ErrorCodeEnum CHSPScannerFSM::TryToOpenDevice()
{
	ErrorCodeEnum result(Error_Succeed);
	m_bOpening = true;

    result = m_hDevHelper->DevOpen();
    if (FAILURED(result)) {
        SetErrPackage(m_errPkg, "OnInit::DevOpen", m_csDevNo, result, MEC_DEVAPI_HSPSCANNER_DevOpen);
        AlarmDEC(m_errPkg);
		SetLastUserCode(LOG_ERR_HSPS_DEVOPEN_FAILED);
    } else {
		SetLastUserCode();
        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Open HSPS succ");
        ZeroMemory(m_devCat.szModel, sizeof(m_devCat.szModel));
        ZeroMemory(m_devCat.szType, sizeof(m_devCat.szType));
        ZeroMemory(m_devCat.szVendor, sizeof(m_devCat.szVendor));
        result = m_hDevHelper->GetDevCategory(m_devCat);
        if (result == Error_Succeed) {
            DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("szVendor:%s,szType:%s,szModel:%s,version:%d.%d.%d.%d", m_devCat.szVendor
                                                         , m_devCat.szType, m_devCat.szModel, m_devCat.version.wMajor, m_devCat.version.wMinor, m_devCat.version.wRevision, m_devCat.version.wBuild);
            m_adapterInfo.devCatInfo = m_devCat;
        } else {
            SetErrPackage(m_errPkg, "OnInit::GetDevCategory", m_csDevNo, result, MEC_DEVAPI_HSPSCANNER_GetDevCategory);
            AlarmDEC(m_errPkg);
        }

        m_bOpened = true;
        {
            m_nRecX = 1280;
            m_nRecY = 0;
            m_nRecW = 1920;
            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);
            DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("ViewPos: %s, Scan: %s, rotate: %s, color: %s.", SpStrError(ecInit), SpStrError(ecInitScan), SpStrError(ecInitRotate), SpStrError(ecInitColor));
        }
        m_eDevStatus = DEVICE_STATUS_NORMAL;
    }

	m_bOpening = false;
    return result;
}