myvtm/Module/mod_UpgradeMgr/UpgradeTaskFSM.cpp

#include "UpgradeTaskFSM.h"
#include "fileutil.h"
#include "iniutil.h"
#include "memutil.h"

#include "RVCComm.h"
#include <regex>
#include "mod_UpgradeMgr.h"
#include "UpgradeManager_msg_g.h"

#ifdef RVC_OS_WIN
#include <WinBase.h>
#include <io.h>
#include "EventCode.h"
#include "UpgradeMgr_UserCode.h"
#include "json.h"
#include "XUnzip.h"
#include <ShellAPI.h>
#else
#include "EventCode.h"
#include "json/json.h"
#include <sys/utsname.h>
#include "XUnZipZilb.h"
#endif

namespace Task
{
	//获取文件hash值工作线程并发送hash值给总行(废弃的方法)
	struct GetSM3Task : public ITaskSp
	{
		CUpgradeTaskFSM* m_fsm;
		explicit GetSM3Task(CUpgradeTaskFSM* f) : m_fsm(f) {}
		void Process(){
			LOG_FUNCTION();
			bool createSM3 = false;

			while(true){

				//计算hash值
				if(m_fsm->m_fileSM3ListHash.IsNullOrEmpty()){
					if(getSM3Hash()){
						m_fsm->m_isSM3HashSucc = true;//计算成功
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetSM3Task")("get SM3 list succ, len=%d, fileNum = %d, SM3 hash=%s", m_fsm->m_fileSM3List.GetLength(), m_fsm->m_fileSM3Map.size(), m_fsm->m_fileSM3ListHash.GetData());
					}else{
						LogWarn(Severity_Middle, Error_Exception, ERR_TASK_GET_SM3_HASH_FAIL, "get SM3 list fail");
						Sleep(60*1000);//等待一分钟再继续计算hash
						continue;
					}
				}
				//发送hash值
				if(sendSM3Hash()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetSM3Task")("send SM3 list succ");
					break;
				}else{
					Sleep(90*1000);//等待90s再上传
					LogWarn(Severity_Middle, Error_Exception, ERR_TASK_SEND_SM3_HASH_FAIL, "send SM3 list fail");
					continue;
				}
			}
		}

		bool getSM3Hash(){
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("getSM3Hash")("begin get SM3 list");
			CSmallDateTime beginT = CSmallDateTime::GetNow();
			CSimpleStringA tempSM3ListStr = "";
			ErrorCodeEnum rc = m_fsm->GetSM3List(tempSM3ListStr);
			CSmallDateTime endT = CSmallDateTime::GetNow();
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("getSM3Hash")("get SM3 list 耗时%d秒",(DWORD)(endT-beginT));

			if (rc != Error_Succeed)
			{
				LogError(Severity_Middle, rc, 0, "get SM3 list fail");
				return false;
			}
			else
			{
				//tempSM3ListStr 这个值有可能因为配置的文件夹下面没有文件，故为空
				if(tempSM3ListStr.IsNullOrEmpty()){
					m_fsm->m_fileSM3ListHash = "TerminalTempHash";
					m_fsm->m_isSM3HashSucc = true;//设置计算成功
					return true;
				}else{
					CSimpleStringA tempSM3HashStr = "";
					if(Error_Succeed==m_fsm->SM3DataToStr(tempSM3ListStr,tempSM3HashStr,false)){
						m_fsm->m_fileSM3ListHash = tempSM3HashStr;
						m_fsm->m_isSM3HashSucc = true;//设置计算成功
						return true;
					}else{
						LogError(Severity_Middle, rc, 0, "get SM3 list hash fail");
						return false;
					}
				}
			}
		}

		bool sendSM3Hash(){
			LOG_FUNCTION();
			if(!m_fsm->m_isSM3HashSucc){
				return false;
			}

			IHttpFunc* client;
			client = create_http(m_fsm->HttpsLogCallBack);
			//发送hash
			bool bRet = SendSM3TaskImpl(client);
			if(bRet){
				m_fsm->isSendHash = true;//可发送hash码
			}else{
				m_fsm->isSendHash = false;
			}
			client->Destory();
			return bRet;
		}

		bool SendSM3TaskImpl(IHttpFunc* client){
			HttpStruct::SendSM3TaskReq qTempReq;
			HttpStruct::SendSM3TaskRet qTempRet;

			CSystemStaticInfo info;
			ErrorCodeEnum rc = m_fsm->GetEntityBase()->GetFunction()->GetSystemStaticInfo(info);
			if (rc != Error_Succeed)
			{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("SendSM3TaskImpl")("SendSM3Task get CSystemStaticInfo fail");
				return false;
			}

			Json::Value rootReq;
			Json::FastWriter writer;
			rootReq["terminal_no"] = info.strTerminalID.GetData();
			rootReq["software_version"] = m_fsm->m_currentVersion.ToString().GetData();
			rootReq["file_hash_list"] = m_fsm->m_fileSM3List.GetData();//hash集合
			rootReq["list_hash"] = m_fsm->m_fileSM3ListHash.GetData();//64位

			string jsonReq = writer.write(rootReq);
			qTempReq.m_reqStr = jsonReq;//请求参数
			qTempReq.m_url=m_fsm->m_centerUrl.sendSM3TaskUrl;//访问地址
			qTempReq.m_timeOut = 60;//设置传送超时时间为60s

			//打印发送请求
			if(m_fsm->m_PrintHttpLog){
				qTempReq.m_printDbg = true;
			}

			if(!client->Post(qTempReq, qTempRet)){
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_SEND_SM3_HASH_FAIL,CSimpleStringA::Format("SendSM3Task http req fail,url=%s, err=%s",qTempReq.m_url.c_str(),qTempRet.m_errMsg.c_str()).GetData());
				return false;//失败
			}

			//打印回应报文
			if(m_fsm->m_PrintHttpLog){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("SendSM3TaskImpl")("qTempRet=%s",qTempRet.m_retStr.c_str());
			}

			Json::Reader reader;
			Json::Value rootRet;
			if (!reader.parse(qTempRet.m_retStr, rootRet, false))
			{
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_SEND_SM3_HASH_FAIL,CSimpleStringA::Format("SendSM3Task parse resp is fail,url=%s",qTempReq.m_url.c_str()).GetData());
				return false;//失败
			}

			bool isSucc = rootRet["success"].asBool();
			if(isSucc){
				if(rootRet.isMember("data")){
					if(rootRet["data"].asBool()){
						return true;//写入成功
					}else{
						return false;//写入失败
					}
				}else{
					return false;//写入失败
				}
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("SendSM3TaskImpl")("SendSM3Task [success] is false");
				return false;//写入失败
			}
		}

	};

	//计算和发送文件hash
	struct SendSM3Task : public ITaskSp{
		CUpgradeTaskFSM* m_fsm;
		explicit SendSM3Task(CUpgradeTaskFSM* f) : m_fsm(f) {}
		void Process(){
			LOG_FUNCTION();

			int tryCount=3;//总共3次机会
			bool SendHashOK= false; 

			while(tryCount>0){
				//计算hash
				if(m_fsm->m_fileSM3ListHash.IsNullOrEmpty()){
					if(getSM3Hash()){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetSM3Task")("get SM3 list succ, len=%d, fileNum = %d, SM3 hash=%s", m_fsm->m_fileSM3List.GetLength(), m_fsm->m_fileSM3Map.size(), m_fsm->m_fileSM3ListHash.GetData());
					}else{
						LogWarn(Severity_Middle, Error_Exception, ERR_TASK_GET_SM3_HASH_FAIL, "get SM3 list fail");
						tryCount--;
						Sleep(60*1000);//等待60s再计算
						continue;
					}
				}
				//发送hash
				if(sendSM3Hash()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetSM3Task")("send SM3 list succ");
					m_fsm->isSendHash=true;
					SendHashOK = true;
					break;
				}else{
					LogWarn(Severity_Middle, Error_Exception, ERR_TASK_SEND_SM3_HASH_FAIL, "send SM3 list fail");
					m_fsm->isSendHash=false;
					Sleep(60*1000);//等待60s再上传
					tryCount--;
					continue;
				}
			}
			
			m_fsm->PostEventFIFO(new CUpgradeTaskFSM::SendSM3TaskEvent(SendHashOK));//返回处理结果
		}

		bool getSM3Hash(){
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("getSM3Hash")("begin get SM3 list");
			CSmallDateTime beginT = CSmallDateTime::GetNow();
			CSimpleStringA tempSM3ListStr = "";
			ErrorCodeEnum rc = m_fsm->GetSM3List(tempSM3ListStr);
			CSmallDateTime endT = CSmallDateTime::GetNow();
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("getSM3Hash")("get SM3 list 耗时%d秒",(DWORD)(endT-beginT));

			if (rc != Error_Succeed)
			{
				LogError(Severity_Middle, rc, 0, "get SM3 list fail");
				return false;
			}
			else
			{
				//tempSM3ListStr 这个值有可能因为配置的文件夹下面没有文件，故为空
				if(tempSM3ListStr.IsNullOrEmpty()){
					m_fsm->m_fileSM3ListHash = "TerminalTempHash";
					return true;
				}else{
					CSimpleStringA tempSM3HashStr = "";
					if(Error_Succeed==m_fsm->SM3DataToStr(tempSM3ListStr,tempSM3HashStr,false)){
						m_fsm->m_fileSM3ListHash = tempSM3HashStr;
						return true;
					}else{
						LogError(Severity_Middle, rc, 0, "get SM3 list hash fail");
						return false;
					}
				}
			}
		}

		bool sendSM3Hash(){
			//LOG_FUNCTION();
			IHttpFunc* client;
			client = create_http(m_fsm->HttpsLogCallBack);
			//发送hash
			bool bRet = SendSM3TaskImpl(client);
			client->Destory();
			return bRet;
		}

		bool SendSM3TaskImpl(IHttpFunc* client){
			HttpStruct::SendSM3TaskReq qTempReq;
			HttpStruct::SendSM3TaskRet qTempRet;

			CSystemStaticInfo info;
			ErrorCodeEnum rc = m_fsm->GetEntityBase()->GetFunction()->GetSystemStaticInfo(info);
			if (rc != Error_Succeed)
			{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("SendSM3TaskImpl")("SendSM3Task get CSystemStaticInfo fail");
				return false;
			}

			Json::Value rootReq;
			Json::FastWriter writer;
			rootReq["terminal_no"] = info.strTerminalID.GetData();
			rootReq["software_version"] = m_fsm->m_currentVersion.ToString().GetData();
			rootReq["file_hash_list"] = m_fsm->m_fileSM3List.GetData();//hash集合
			rootReq["list_hash"] = m_fsm->m_fileSM3ListHash.GetData();//64位

			string jsonReq = writer.write(rootReq);
			qTempReq.m_reqStr = jsonReq;//请求参数
			qTempReq.m_url=m_fsm->m_centerUrl.sendSM3TaskUrl;//访问地址
			qTempReq.m_timeOut = 60;//设置传送超时时间为60s

			//打印发送请求
			if(m_fsm->m_PrintHttpLog){
				qTempReq.m_printDbg = true;
			}

			if(!client->Post(qTempReq, qTempRet)){
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_SEND_SM3_HASH_FAIL,CSimpleStringA::Format("SendSM3Task http req fail,url=%s, err=%s",qTempReq.m_url.c_str(),qTempRet.m_errMsg.c_str()).GetData());
				return false;//失败
			}

			//打印回应报文
			if(m_fsm->m_PrintHttpLog){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("SendSM3TaskImpl")("qTempRet=%s",qTempRet.m_retStr.c_str());
			}

			Json::Reader reader;
			Json::Value rootRet;
			if (!reader.parse(qTempRet.m_retStr, rootRet, false))
			{
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_SEND_SM3_HASH_FAIL,CSimpleStringA::Format("SendSM3Task parse resp is fail,url=%s",qTempReq.m_url.c_str()).GetData());
				return false;//失败
			}

			bool isSucc = rootRet["success"].asBool();
			if(isSucc){
				if(rootRet.isMember("data")){
					if(rootRet["data"].asBool()){
						return true;//写入成功
					}else{
						return false;//写入失败
					}
				}else{
					return false;//写入失败
				}
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("SendSM3TaskImpl")("SendSM3Task [success] is false");
				return false;//写入失败
			}
		}
	};

	//更新任务状态
	struct UpdateTaskStatus : public ITaskSp{
		CUpgradeTaskFSM* m_fsm;
		explicit UpdateTaskStatus(CUpgradeTaskFSM* f) : m_fsm(f) {}
		void Process(){
			LOG_FUNCTION();
			IHttpFunc* client;
			client = create_http(m_fsm->HttpsLogCallBack);
			bool isSendSucc=false;//更新是否成功标志
			if(UpdateTaskStatusImpl(client)){
				isSendSucc = true;
			}else{
				isSendSucc = false;
			}
			client->Destory();
			m_fsm->PostEventFIFO(new CUpgradeTaskFSM::UpdateTaskStatusEvent(isSendSucc));//返回处理结果
		}

		bool UpdateTaskStatusImpl(IHttpFunc* client){
			CSystemStaticInfo info;
			ErrorCodeEnum rc = m_fsm->GetEntityBase()->GetFunction()->GetSystemStaticInfo(info);
			if (rc != Error_Succeed)
			{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UpdateTaskStatusImpl")("UpdateTaskStatus get CSystemStaticInfo fail,upgradeTaskId=%s",m_fsm->m_currentTask.upgradeTaskId.GetData());
				return false;
			}

			HttpStruct::UpdateTaskStatusReq qTempReq;
			HttpStruct::UpdateTaskStatusRet qTempRet;

			Json::Value rootReq;
			Json::FastWriter writer;
			rootReq["terminal_no"] = info.strTerminalID.GetData();
			rootReq["task_id"] = m_fsm->m_currentTask.upgradeTaskId.GetData();

			//状态为C时，为X时，或者T，版本不一致，则是回退，否则是成功
			//返回任务结果给服务器
			if(m_fsm->m_currentTask.cPendingState=="C"){
				rootReq["upgrade_status"] = "F";//失败

			}else if(m_fsm->m_currentTask.cPendingState=="X"){
				rootReq["upgrade_status"] = "X";//未知状态

			}else if(m_fsm->m_currentTask.cPendingState=="T"){
				if(m_fsm->m_currentTask.NewVersion==m_fsm->m_currentVersion.ToString()||m_fsm->m_currentTask.NewVersion==""){
					//升级成功
					rootReq["upgrade_status"] = "S";//成功
				}else{
					//升级失败,回滚版本导致
					rootReq["upgrade_status"] = "F";//失败
				}

			}

			string jsonReq = writer.write(rootReq);
			qTempReq.m_reqStr = jsonReq;//请求参数
			
			qTempReq.m_url=m_fsm->m_centerUrl.updateTaskUrl;//访问地址

			//打印发送请求
			if(m_fsm->m_PrintHttpLog){
				qTempReq.m_printDbg = true;
			}
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UpdateTaskStatusImpl")("UpdateTaskStatus req=%s",qTempReq.m_reqStr.c_str());

			if(!client->Post(qTempReq, qTempRet)){
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_TASK_STATUS_FAIL,CSimpleStringA::Format("UpdateTaskStatus http req fail, upgradeTaskId=%s, url=%s, err=%s",m_fsm->m_currentTask.upgradeTaskId.GetData(),qTempReq.m_url.c_str(),qTempRet.m_errMsg.c_str()).GetData());
				return false;//失败
			}

			//打印回应报文
			if(m_fsm->m_PrintHttpLog){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UpdateTaskStatusImpl")("qTempRet=%s",qTempRet.m_retStr.c_str());
			}
			Json::Reader reader;
			Json::Value rootRet;
			if (!reader.parse(qTempRet.m_retStr, rootRet, false))
			{		
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_TASK_STATUS_FAIL,CSimpleStringA::Format("UpdateTaskStatus parse resp is fail, upgradeTaskId=%s, url=%s",m_fsm->m_currentTask.upgradeTaskId.GetData(),qTempReq.m_url.c_str()).GetData());
				return false;//失败
			}
			bool isSucc = rootRet["success"].asBool();
			if(isSucc){
				if(rootRet.isMember("data")){

					int isUpdate =rootRet["data"].asInt();
					//0:更新失败 1:更新成功 2:任务不属于此终端等异常情况，默认成功
					if(isUpdate==0){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UpdateTaskStatusImpl")("UpdateTaskStatus update fail: upgradeTaskId=%s",m_fsm->m_currentTask.upgradeTaskId.GetData());
						return false;//更新失败
					}else if(isUpdate==1){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UpdateTaskStatusImpl")("UpdateTaskStatus update succ: upgradeTaskId=%s",m_fsm->m_currentTask.upgradeTaskId.GetData());
						return true;//更新成功
					}else if(isUpdate==2){
						LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_TASK_STATUS_INVALID,CSimpleStringA::Format("UpdateTaskStatus update invalid,upgradeTaskId=%s",m_fsm->m_currentTask.upgradeTaskId.GetData()).GetData());
					    return true;//任务异常，更新成功
					}else{
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UpdateTaskStatusImpl")("UpdateTaskStatus update fail: upgradeTaskId=%s, ret=%d",m_fsm->m_currentTask.upgradeTaskId.GetData(),isUpdate);
						return false;//更新失败
					}
				}else{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UpdateTaskStatusImpl")("UpdateTaskStatus update fail: [data] is not exist ,upgradeTaskId=%s",m_fsm->m_currentTask.upgradeTaskId.GetData());
					return false;//更新失败
				}
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UpdateTaskStatusImpl")("UpdateTaskStatus update fail: [success] is false,upgradeTaskId=%s",m_fsm->m_currentTask.upgradeTaskId.GetData());
				return false;//更新失败
			}
		}

	};

	//查询当前任务
	struct QueryCurrTask : public ITaskSp{
		CUpgradeTaskFSM* m_fsm;
		explicit QueryCurrTask(CUpgradeTaskFSM* f) : m_fsm(f) {}
		void Process(){
			LOG_FUNCTION();
			//根据任务ID查询任务当前的策略。
			IHttpFunc* client;
			client = create_http(m_fsm->HttpsLogCallBack);

			bool isSendSucc=false;//查询是否成功标志
			bool isTask_valid=false;//任务是否有效

			if(QueryCurrTaskImpl(client,isTask_valid)){
				isSendSucc = true;
			}else{
				isSendSucc = false;
			}

			client->Destory();
			m_fsm->PostEventFIFO(new CUpgradeTaskFSM::QueryCurrTaskEvent(isSendSucc,isTask_valid));//返回处理结果
		}

		bool QueryCurrTaskImpl(IHttpFunc* client,bool &isValid){
			HttpStruct::QueryCurrTaskReq qTempReq;
			HttpStruct::QueryCurrTaskRet qTempRet;

			CSystemStaticInfo info;
			ErrorCodeEnum rc = m_fsm->GetEntityBase()->GetFunction()->GetSystemStaticInfo(info);
			if (rc != Error_Succeed)
			{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryCurrTaskImpl")("QueryNewTask get CSystemStaticInfo fail");
				return false;
			}
			//机器版本
			CSimpleStringA strMachineVersion = CSimpleStringA::Format("%d.%d",info.MachineVersion.GetMajor(),info.MachineVersion.GetMinor());
			//框架版本
			CSimpleStringA strInstallVersion = m_fsm->m_currentVersion.ToString();
			// OS版本
#ifdef RVC_OS_WIN
			OSVERSIONINFO osvi;    
			ZeroMemory(&osvi, sizeof(OSVERSIONINFO));
			osvi.dwOSVersionInfoSize = sizeof(OSVERSIONINFO);
			GetVersionEx(&osvi);
			CSimpleStringA strOSVersion = CSimpleStringA::Format("%d.%d.%d",osvi.dwMajorVersion,osvi.dwMinorVersion,osvi.dwBuildNumber);
#else
			DWORD dwMajorVersion(0), dwMinorVersion(0), dwBuildNumber(0);
			struct utsname kernel_info;
			int ret = uname(&kernel_info);
			if (ret == 0) {
				int n = sscanf((const char*)kernel_info.release, "%d.%d", &dwMajorVersion, &dwMinorVersion);
			}
			else {
				Dbg("get linux kernel version fail: %s", strerror(errno));
			}
			CSimpleStringA strOSVersion = CSimpleStringA::Format("%d.%d.0", dwMajorVersion, dwMinorVersion);
#endif
			Json::Value rootReq;
			Json::FastWriter writer;
			rootReq["terminal_no"] = info.strTerminalID.GetData();
			rootReq["task_id"] = m_fsm->m_currentTask.upgradeTaskId.GetData();
			rootReq["machine_type"] = info.strMachineType.GetData();
			rootReq["software_version"] = strInstallVersion.GetData();
			rootReq["os_version"] = strOSVersion.GetData();
			rootReq["machine_version"] = strMachineVersion.GetData();
			
			string jsonReq = writer.write(rootReq);
			qTempReq.m_reqStr = jsonReq;//请求参数

			qTempReq.m_url=m_fsm->m_centerUrl.queryCurrTaskUrl;//访问地址

			//打印发送请求
			if(m_fsm->m_PrintHttpLog){
				qTempReq.m_printDbg = true;
			}

			if(!client->Post(qTempReq, qTempRet)){
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_CURR_TASK_FAIL,CSimpleStringA::Format("QueryCurrTask http req fail,url=%s, err=%s",qTempReq.m_url.c_str(),qTempRet.m_errMsg.c_str()).GetData());
				return false;//失败
			}

			//打印回应报文
			if(m_fsm->m_PrintHttpLog){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryCurrTaskImpl")("qTempRet=%s",qTempRet.m_retStr.c_str());
			}

			Json::Reader reader;
			Json::Value rootRet;
			if (!reader.parse(qTempRet.m_retStr, rootRet, false))
			{
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_CURR_TASK_FAIL,CSimpleStringA::Format("QueryCurrTask parse resp is fail,url=%s",qTempReq.m_url.c_str()).GetData());
				return false;//失败
			}

			bool isSucc = rootRet["success"].asBool();
			if(isSucc){
				if(rootRet.isMember("data")){
					if(rootRet["data"]["task_status"].asBool()){
						isValid = true;//任务有效
						if(!ParamCheck(rootRet)){
							LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_CURR_TASK_FAIL,CSimpleStringA::Format("QueryCurrTask paramCheck is fail, retry once again ,url=%s",qTempReq.m_url.c_str()).GetData());
							return false;//查询失败 升级任务参数效验失败，无法进行升级
						}else{
							CSimpleStringA packNameStr = rootRet["data"]["pack_name"].asString().c_str();
							if(m_fsm->m_currentTask.pack_name!=packNameStr){
								//异常情况
								CSimpleStringA errmsg =  CSimpleStringA::Format("runinfo packName[%s] is not equal server packName[%s]",m_fsm->m_currentTask.pack_name.GetData(),packNameStr.GetData());
								LogWarn(Severity_Middle, Error_Exception, ERR_TASK_PACKNAME_NOT_EQUAL, errmsg.GetData());
							}
							m_fsm->m_currentTask.pack_name= packNameStr;//用最新的包名进行后面的安装和下载
							m_fsm->m_currentTask.file_path = rootRet["data"]["file_path"].asString().c_str();
							m_fsm->m_currentTask.download_url = rootRet["data"]["download_url"].asString().c_str();
							m_fsm->m_currentTask.pack_hash = rootRet["data"]["pack_hash"].asString().c_str();
							m_fsm->m_currentTask.pack_length = (long)rootRet["data"]["pack_length"].asInt();
							m_fsm->m_currentTask.pack_version = rootRet["data"]["pack_version"].asString().c_str();
							m_fsm->m_currentTask.reboot_type = rootRet["data"]["reboot_type"].asInt();
							m_fsm->m_currentTask.stop_media_play = rootRet["data"]["stop_media_play"].asBool();
							
							//解析step json
							if(!ParseInstallStep(rootRet)){
								m_fsm->ClearInstallStep();
								LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_CURR_TASK_FAIL,CSimpleStringA::Format("QueryCurrTask ParseInstallStep is fail, retry once again ,url=%s",qTempReq.m_url.c_str()).GetData());
								return false;//解析安装步骤失败
							}
							DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryCurrTaskImpl")("current task id =%s",m_fsm->m_currentTask.upgradeTaskId.GetData());
							return true;//查询成功
						}
						
					}else{
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryCurrTaskImpl")("QueryCurrTask query task is invalid, taskid=%s",m_fsm->m_currentTask.upgradeTaskId.GetData());
						isValid = false;//任务无效
						return true;//查询成功
					}	
				}else{
					LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_CURR_TASK_FAIL,CSimpleStringA::Format("QueryCurrTask return task [data] is null ,url=%s",qTempReq.m_url.c_str()).GetData());
					return false;//查询失败
				}
			}else{
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_CURR_TASK_FAIL,CSimpleStringA::Format("QueryCurrTask [success] is false ,url=%s",qTempReq.m_url.c_str()).GetData());
				return false;//查询失败
			}
		}

		bool ParamCheck(Json::Value rootRet){
			CSimpleStringA packNameStr = rootRet["data"]["pack_name"].asString().c_str();
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryCurrTask paramCheck [pack_name] is %s",packNameStr.GetData());
			if(packNameStr.IsNullOrEmpty()){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryCurrTask paramCheck [pack_name] is null");
				return false;
			}

			CSimpleStringA filePathStr = rootRet["data"]["file_path"].asString().c_str();
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryCurrTask paramCheck [file_path] is %s",filePathStr.GetData());
			if(filePathStr.IsNullOrEmpty()){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryCurrTask paramCheck [file_path] is null");
				return false;
			}

			CSimpleStringA downloadUrlStr = rootRet["data"]["download_url"].asString().c_str();
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryCurrTask paramCheck [download_url] is %s",downloadUrlStr.GetData());
			if(downloadUrlStr.IsNullOrEmpty()){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryCurrTask paramCheck [download_url] is null");
				return false;
			}

			CSimpleStringA packHashStr = rootRet["data"]["pack_hash"].asString().c_str();
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryCurrTask paramCheck [pack_hash] is %s",packHashStr.GetData());
			if(packHashStr.IsNullOrEmpty()){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryCurrTask paramCheck [pack_hash] is null");
				return false;
			}

			long packLengthLong = (long)rootRet["data"]["pack_length"].asInt();
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryCurrTask paramCheck [pack_length] is %d",packLengthLong);


			int rebootTypeInt = rootRet["data"]["reboot_type"].asInt();
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryCurrTask paramCheck [reboot_type] is %d",rebootTypeInt);
			if(rebootTypeInt!=1 && rebootTypeInt!=2 && rebootTypeInt!=0){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryCurrTask paramCheck [reboot_type] is invalid ,reboot_type=%d",rebootTypeInt);
				return false;
			}

			CSimpleStringA packVersionStr = rootRet["data"]["pack_version"].asString().c_str();
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryCurrTask paramCheck [pack_version] is %s",packVersionStr.GetData());
			if(!packVersionStr.IsNullOrEmpty()){
				int rebootType = rootRet["data"]["reboot_type"].asInt();
				if(rebootType == 1 || rebootType == 2){
					return true;
				}else{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryCurrTask paramCheck [pack_version] is not null ,[reboot_type] is not equal 1 or 2");
					return false;
				}
			}

			return true;
		}

		bool ParseInstallStep(Json::Value rootRet){
			//清理以前的遗留的安装步骤
			m_fsm->ClearInstallStep();

			string cmdstr = rootRet["data"]["cmd"].asString();
			if(cmdstr.empty()){
				return true;//为空则直接不解析
			}

			Json::Reader reader;
			Json::Value InstallRet;
			if (!reader.parse(cmdstr, InstallRet, false))
			{
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_CURR_TASK_FAIL,CSimpleStringA::Format("QueryCurrTask parse cmd fail,cmdstr=%s",cmdstr.c_str()).GetData());
				return false;//解析失败
			}

			//install_step
			for(int i=0;i<InstallRet.size();i++){

				if(!InstallRet[i]["seq"].isInt()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryCurrTask ParseInstallStep [cmd][seq] is not int");
					return false;
				}
				int stepSeq =  InstallRet[i]["seq"].asInt();

				if(!InstallRet[i]["cmdType"].isString()&&!InstallRet[i]["cmdType"].isNull()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryCurrTask ParseInstallStep [cmd][cmdType] is not string");
					return false;
				}
				CSimpleStringA cmdType =  InstallRet[i]["cmdType"].asString().c_str();
				if(cmdType.IsNullOrEmpty()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryCurrTask ParseInstallStep [cmd][cmdType] is null");
					return false;
				}

				if(!InstallRet[i]["cmdFail"].isInt()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryCurrTask ParseInstallStep [cmd][cmdFail] is not int");
					return false;
				}
				int cmdFail =  InstallRet[i]["cmdFail"].asInt();

				if(!InstallRet[i]["srcPathType"].isString()&&!InstallRet[i]["srcPathType"].isNull()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryCurrTask ParseInstallStep [cmd][srcPathType] is not string");
					return false;
				}
				CSimpleStringA srcPathType =  InstallRet[i]["srcPathType"].asString().c_str();
				if(cmdType=="Copy"){
					//复制指令时，不为空
					if(srcPathType.IsNullOrEmpty()){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryCurrTask ParseInstallStep [cmd][srcPathType] is null");
						return false;
					}
				}

				if(!InstallRet[i]["srcPath"].isString()&&!InstallRet[i]["srcPath"].isNull()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryCurrTask ParseInstallStep [cmd][srcPath] is not string");
					return false;
				}
				CSimpleStringA srcPath =  InstallRet[i]["srcPath"].asString().c_str();
				if(cmdType=="Copy"){
					//复制指令时，不为空
					if(srcPath.IsNullOrEmpty()){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryCurrTask ParseInstallStep [cmd][srcPath] is null");
						return false;
					}
				}

				if(!InstallRet[i]["dstPathType"].isString()&&!InstallRet[i]["dstPathType"].isNull()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryCurrTask ParseInstallStep [cmd][dstPathType] is not string");
					return false;
				}
				CSimpleStringA dstPathType =  InstallRet[i]["dstPathType"].asString().c_str();
				if(cmdType=="Copy"||cmdType=="Delete"||cmdType=="Run"){
					if(dstPathType.IsNullOrEmpty()){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryCurrTask ParseInstallStep [cmd][dstPathType] is null");
						return false;
					}
				}

				if(!InstallRet[i]["dstPath"].isString()&&!InstallRet[i]["dstPath"].isNull()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryCurrTask ParseInstallStep [cmd][dstPath] is not string");
					return false;
				}
				CSimpleStringA dstPath =  InstallRet[i]["dstPath"].asString().c_str();
				if(cmdType=="Delete"||cmdType=="Run"){
					if(dstPath.IsNullOrEmpty()){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryCurrTask ParseInstallStep [cmd][dstPath] is null");
						return false;
					}
				}

				CUpgradeTaskFSM::CInstallStep* iStep= new CUpgradeTaskFSM::CInstallStep();
				iStep->stepSeq = stepSeq;
				iStep->cmdType = cmdType;
				iStep->cmdFail = cmdFail;
				iStep->srcPathType = srcPathType;
				iStep->srcPath = srcPath;
				iStep->dstPathType =dstPathType;
				iStep->dstPath =dstPath;
				m_fsm->m_currentTask.install_step.push(iStep);//加入队尾
			}
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("install cmd size = %d",InstallRet.size());
			return true;

		}
	};

	//查询新任务(旧版本使用)
	struct QueryNewTask : public ITaskSp{
		CUpgradeTaskFSM* m_fsm;
		explicit QueryNewTask(CUpgradeTaskFSM* f) : m_fsm(f) {}
		void Process(){
			LOG_FUNCTION();
			IHttpFunc* client;
			client = create_http(m_fsm->HttpsLogCallBack);
			//查询新任务
			bool isSendSucc=false;////查询是否成功标志
			if(QueryNewTaskImpl(client)){
				isSendSucc = true;
			}else{
				isSendSucc = false;
			}
			client->Destory();
			m_fsm->PostEventFIFO(new CUpgradeTaskFSM::QueryNewTaskEvent(isSendSucc));//返回处理结果
		}

		bool QueryNewTaskImpl(IHttpFunc* client){
			HttpStruct::QueryNewTaskReq qTempReq;
			HttpStruct::QueryNewTaskRet qTempRet;

			CSystemStaticInfo info;
			ErrorCodeEnum rc = m_fsm->GetEntityBase()->GetFunction()->GetSystemStaticInfo(info);
			if (rc != Error_Succeed)
			{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryNewTaskImpl")("QueryNewTask get CSystemStaticInfo fail");
				return false;
			}
			//机器版本
			CSimpleStringA strMachineVersion = CSimpleStringA::Format("%d.%d",info.MachineVersion.GetMajor(),info.MachineVersion.GetMinor());
			//框架版本
			CSimpleStringA strInstallVersion = m_fsm->m_currentVersion.ToString();
			// OS版本
#ifdef RVC_OS_WIN
			OSVERSIONINFO osvi;    
			ZeroMemory(&osvi, sizeof(OSVERSIONINFO));
			osvi.dwOSVersionInfoSize = sizeof(OSVERSIONINFO);
			GetVersionEx(&osvi);
			CSimpleStringA strOSVersion = CSimpleStringA::Format("%d.%d.%d",osvi.dwMajorVersion,osvi.dwMinorVersion,osvi.dwBuildNumber);
#else
			DWORD dwMajorVersion(0), dwMinorVersion(0), dwBuildNumber(0);
			struct utsname kernel_info;
			int ret = uname(&kernel_info);
			if (ret == 0) {
				int n = sscanf((const char*)kernel_info.release, "%d.%d", &dwMajorVersion, &dwMinorVersion);
			}
			else {
				Dbg("get linux kernel version fail: %s", strerror(errno));
			}
			CSimpleStringA strOSVersion = CSimpleStringA::Format("%d.%d.0", dwMajorVersion, dwMinorVersion);
#endif
			Json::Value rootReq;
			Json::FastWriter writer;
			rootReq["terminal_no"] = info.strTerminalID.GetData();
			rootReq["machine_type"] = info.strMachineType.GetData();
			rootReq["software_version"] = strInstallVersion.GetData();
			rootReq["os_version"] = strOSVersion.GetData();
			rootReq["machine_version"] = strMachineVersion.GetData();
#ifdef RVC_OS_WIN
#else
			rootReq["system_type"] = "L";
#endif			
			

			//是否发送hash码
			if(m_fsm->isSendHash){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryNewTaskImpl")("QueryNewTask with hash");
				rootReq["list_hash"] = m_fsm->m_fileSM3ListHash.GetData();
				rootReq["file_hash_list"] = "";//m_fsm->m_fileSM3List.GetData();防止字符串太大，所以提前上传hashlist
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryNewTaskImpl")("QueryNewTask with no hash");
				rootReq["list_hash"] = "";
				rootReq["file_hash_list"] = "";
			}

			string jsonReq = writer.write(rootReq);
			qTempReq.m_reqStr = jsonReq;//请求参数
			qTempReq.m_url=m_fsm->m_centerUrl.queryNewTaskUrl;//访问地址

			//打印发送请求
			if(m_fsm->m_PrintHttpLog){
				qTempReq.m_printDbg = true;
			}

			if(!client->Post(qTempReq, qTempRet)){
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewTask http req fail,url=%s, err=%s",qTempReq.m_url.c_str(),qTempRet.m_errMsg.c_str()).GetData());
				return false;//失败
			}

			//打印回应报文
			if(m_fsm->m_PrintHttpLog){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryNewTaskImpl")("qTempRet=%s",qTempRet.m_retStr.c_str());
			}

			Json::Reader reader;
			Json::Value rootRet;
			if (!reader.parse(qTempRet.m_retStr, rootRet, false))
			{
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewTask parse resp is fail,url=%s",qTempReq.m_url.c_str()).GetData());
				return false;//失败
			}

			bool isSucc = rootRet["success"].asBool();
			if(isSucc){
				if(rootRet.isMember("data")){
					//解析任务，可能不存在任务
					if(rootRet["data"]["task_id"].asString()!=""){
						//pack_status 0-准备中 1-已就绪
						int status = rootRet["data"]["pack_status"].asInt();
						if(status == 1){
							if(!ParamCheck(rootRet)){
								LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewTask paramCheck is fail, retry once again ,url=%s",qTempReq.m_url.c_str()).GetData());
								return false;//查询失败 升级任务参数效验失败，无法进行升级
							}else{
								m_fsm->m_currentTask.upgradeTaskId = rootRet["data"]["task_id"].asString().c_str();
								m_fsm->m_currentTask.pack_name = rootRet["data"]["pack_name"].asString().c_str();
								m_fsm->m_currentTask.file_path = rootRet["data"]["file_path"].asString().c_str();
								m_fsm->m_currentTask.download_url = rootRet["data"]["download_url"].asString().c_str();
								m_fsm->m_currentTask.pack_hash = rootRet["data"]["pack_hash"].asString().c_str();
								m_fsm->m_currentTask.pack_length = (long)rootRet["data"]["pack_length"].asInt();
								m_fsm->m_currentTask.pack_version = rootRet["data"]["pack_version"].asString().c_str();
								m_fsm->m_currentTask.reboot_type = rootRet["data"]["reboot_type"].asInt();
								m_fsm->m_currentTask.stop_media_play = rootRet["data"]["stop_media_play"].asBool();

								//解析step json
								if(!ParseInstallStep(rootRet)){
									m_fsm->ClearInstallStep();
									LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewTask ParseInstallStep is fail, retry once again ,url=%s",qTempReq.m_url.c_str()).GetData());
									return false;//解析安装步骤失败
								}

								m_fsm->m_currentTask.createTaskVersion = m_fsm->m_currentVersion.ToString();//新策略，查询到包后，用当前版本值赋值
								DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryNewTaskImpl")("new task id =%s",m_fsm->m_currentTask.upgradeTaskId.GetData());
								return true;//查询成功
							}	
						}else{
						//任务未准备好
							DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryNewTaskImpl")("QueryNewTask query pack is not create ,please next query,status=%d",status);
							m_fsm->m_currentTask.upgradeTaskId = "";
							return true;//查询成功
						}				
					}else{
						//无任务
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryNewTaskImpl")("QueryNewTask query task id is null");
						m_fsm->m_currentTask.upgradeTaskId = "";
						return true;//查询成功
					}
				}else{
					LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewTask return [data] is null, retry once again ,url=%s",qTempReq.m_url.c_str()).GetData());
					return false;//查询失败
				}
			}else{
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewTask [success] is false, retry once again ,url=%s",qTempReq.m_url.c_str()).GetData());
				return false;//查询失败
			}
		}

		bool ParamCheck(Json::Value rootRet){

			CSimpleStringA upgradeTaskIdStr = rootRet["data"]["task_id"].asString().c_str();
			if(upgradeTaskIdStr.IsNullOrEmpty()){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryNewTask paramCheck [task_id] is null");
				return false;
			}
			CSimpleStringA packNameStr = rootRet["data"]["pack_name"].asString().c_str();
			if(packNameStr.IsNullOrEmpty()){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryNewTask paramCheck [pack_name] is null");
				return false;
			}
			CSimpleStringA filePathStr = rootRet["data"]["file_path"].asString().c_str();
			if(filePathStr.IsNullOrEmpty()){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryNewTask paramCheck [file_path] is null");
				return false;
			}
			CSimpleStringA downloadUrlStr = rootRet["data"]["download_url"].asString().c_str();
			if(downloadUrlStr.IsNullOrEmpty()){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryNewTask paramCheck [download_url] is null");
				return false;
			}
			CSimpleStringA packHashStr = rootRet["data"]["pack_hash"].asString().c_str();
			if(packHashStr.IsNullOrEmpty()){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryNewTask paramCheck [pack_hash] is null");
				return false;
			}
			long  packLengthStr = (long)rootRet["data"]["pack_length"].asInt();
			//if(packLengthStr == 0){
			//	Dbg("QueryNewTask paramCheck [pack_length] is 0");
			//	return false;
			//}

			int rebootTypeInt = rootRet["data"]["reboot_type"].asInt();
			if(rebootTypeInt!=1 && rebootTypeInt!=2  && rebootTypeInt!=0){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryNewTask paramCheck [reboot_type] is invalid ,reboot_type=%d",rebootTypeInt);
				return false;
			}

			CSimpleStringA packVersionStr = rootRet["data"]["pack_version"].asString().c_str();
			if(!packVersionStr.IsNullOrEmpty()){
				int rebootType = rootRet["data"]["reboot_type"].asInt();
				if(rebootType == 1 || rebootType == 2){
					return true;
				}else{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryNewTask paramCheck [pack_version] is not null ,[reboot_type] is not equal 1 or 2");
					return false;
				}
			}
			return true;
		}

		bool ParseInstallStep(Json::Value rootRet){
			//清理以前的遗留的安装步骤
			m_fsm->ClearInstallStep();

			string cmdstr = rootRet["data"]["cmd"].asString();
			if(cmdstr.empty()){
				return true;//为空则直接不解析
			}
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("cmdstr =%s",cmdstr.c_str());

			Json::Reader reader;
			Json::Value InstallRet;
			if (!reader.parse(cmdstr, InstallRet, false))
			{
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewTask parse cmd fail,cmdstr=%s",cmdstr.c_str()).GetData());
				return false;//解析失败
			}
			for(int i=0;i<InstallRet.size();i++){

				if(!InstallRet[i]["seq"].isInt()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewTask ParseInstallStep [cmd][seq] is not int");
					return false;
				}
				int stepSeq =  InstallRet[i]["seq"].asInt();
				
				if(!InstallRet[i]["cmdType"].isString()&&!InstallRet[i]["cmdType"].isNull()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewTask ParseInstallStep [cmd][cmdType] is not string");
					return false;
				}
				CSimpleStringA cmdType =  InstallRet[i]["cmdType"].asString().c_str();
				if(cmdType.IsNullOrEmpty()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewTask ParseInstallStep [cmd][cmdType] is null");
					return false;
				}
				

				if(!InstallRet[i]["cmdFail"].isInt()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewTask ParseInstallStep [cmd][cmdFail] is not int");
					return false;
				}
				int cmdFail =  InstallRet[i]["cmdFail"].asInt();
				

				if(!InstallRet[i]["srcPathType"].isString()&&!InstallRet[i]["srcPathType"].isNull()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewTask ParseInstallStep [cmd][srcPathType] is not string");
					return false;
				}
				CSimpleStringA srcPathType =  InstallRet[i]["srcPathType"].asString().c_str();
				if(cmdType=="Copy"){
					//复制指令时，不为空
					if(srcPathType.IsNullOrEmpty()){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewTask ParseInstallStep [cmd][srcPathType] is null");
						return false;
					}
				}
				

				if(!InstallRet[i]["srcPath"].isString()&&!InstallRet[i]["srcPath"].isNull()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewTask ParseInstallStep [cmd][srcPath] is not string");
					return false;
				}
				CSimpleStringA srcPath =  InstallRet[i]["srcPath"].asString().c_str();
				if(cmdType=="Copy"){
					//复制指令时，不为空
					if(srcPath.IsNullOrEmpty()){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewTask ParseInstallStep [cmd][srcPath] is null");
						return false;
					}
				}
				

				if(!InstallRet[i]["dstPathType"].isString()&&!InstallRet[i]["dstPathType"].isNull()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewTask ParseInstallStep [cmd][dstPathType] is not string");
					return false;
				}
				CSimpleStringA dstPathType =  InstallRet[i]["dstPathType"].asString().c_str();
				if(cmdType=="Copy"||cmdType=="Delete"||cmdType=="Run"){
					if(dstPathType.IsNullOrEmpty()){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewTask ParseInstallStep [cmd][dstPathType] is null");
						return false;
					}
				}
				

				if(!InstallRet[i]["dstPath"].isString()&&!InstallRet[i]["dstPath"].isNull()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewTask ParseInstallStep [cmd][dstPath] is not string");
					return false;
				}
				CSimpleStringA dstPath =  InstallRet[i]["dstPath"].asString().c_str();
				if(cmdType=="Delete"||cmdType=="Run"){
					if(dstPath.IsNullOrEmpty()){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewTask ParseInstallStep [cmd][dstPath] is null");
						return false;
					}
				}
				

				CUpgradeTaskFSM::CInstallStep* iStep= new CUpgradeTaskFSM::CInstallStep();
				iStep->stepSeq = stepSeq;
				iStep->cmdType = cmdType;
				iStep->cmdFail = cmdFail;
				iStep->srcPathType = srcPathType;
				iStep->srcPath = srcPath;
				iStep->dstPathType =dstPathType;
				iStep->dstPath =dstPath;
				m_fsm->m_currentTask.install_step.push(iStep);//加入队尾
			}
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("install cmd size = %d",InstallRet.size());
			return true;

		}
	};

	//预查询新任务
	struct QueryNewPreTask : public ITaskSp{
		CUpgradeTaskFSM* m_fsm;
		explicit QueryNewPreTask(CUpgradeTaskFSM* f) : m_fsm(f) {}
		void Process(){
			//LOG_FUNCTION();
			IHttpFunc* client;
			client = create_http(m_fsm->HttpsLogCallBack);
			//查询新任务
			bool isSendSucc=false;////查询是否成功标志
			if(QueryNewPreTaskImpl(client)){
				isSendSucc = true;
			}else{
				isSendSucc = false;
			}
			client->Destory();
			m_fsm->PostEventFIFO(new CUpgradeTaskFSM::QueryNewPreTaskEvent(isSendSucc));//返回处理结果
		}

		bool QueryNewPreTaskImpl(IHttpFunc* client){
			HttpStruct::QueryNewTaskReq qTempReq;
			HttpStruct::QueryNewTaskRet qTempRet;

			CSystemStaticInfo info;
			ErrorCodeEnum rc = m_fsm->GetEntityBase()->GetFunction()->GetSystemStaticInfo(info);
			if (rc != Error_Succeed)
			{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryNewPreTaskImpl")("QueryNewPreTask get CSystemStaticInfo fail");
				return false;
			}
			//机器版本
			CSimpleStringA strMachineVersion = CSimpleStringA::Format("%d.%d",info.MachineVersion.GetMajor(),info.MachineVersion.GetMinor());
			//框架版本
			CSimpleStringA strInstallVersion = m_fsm->m_currentVersion.ToString();
			// OS版本
#ifdef RVC_OS_WIN
			OSVERSIONINFO osvi;
			ZeroMemory(&osvi, sizeof(OSVERSIONINFO));
			osvi.dwOSVersionInfoSize = sizeof(OSVERSIONINFO);
			GetVersionEx(&osvi);
			CSimpleStringA strOSVersion = CSimpleStringA::Format("%d.%d.%d", osvi.dwMajorVersion, osvi.dwMinorVersion, osvi.dwBuildNumber);
#else
			DWORD dwMajorVersion(0), dwMinorVersion(0), dwBuildNumber(0);
			struct utsname kernel_info;
			int ret = uname(&kernel_info);
			if (ret == 0) {
				int n = sscanf((const char*)kernel_info.release, "%d.%d", &dwMajorVersion, &dwMinorVersion);
			}
			else {
				Dbg("get linux kernel version fail: %s", strerror(errno));
			}
			CSimpleStringA strOSVersion = CSimpleStringA::Format("%d.%d.0", dwMajorVersion, dwMinorVersion);
#endif


			Json::Value rootReq;
			Json::FastWriter writer;
			rootReq["terminal_no"] = info.strTerminalID.GetData();
			rootReq["machine_type"] = info.strMachineType.GetData();
			rootReq["software_version"] = strInstallVersion.GetData();
			rootReq["os_version"] = strOSVersion.GetData();
			rootReq["machine_version"] = strMachineVersion.GetData();
			//预查询判断加入查询何种任务。
			if (m_fsm->isTerminalInstall()) {
				rootReq["task_type"] = "I";//安装任务
			}
			else {
				rootReq["task_type"] = "U";//升级任务
			}

			string jsonReq = writer.write(rootReq);
			qTempReq.m_reqStr = jsonReq;//请求参数
			qTempReq.m_url=m_fsm->m_centerUrl.queryPreTaskUrl;//访问地址

			//打印发送请求
			if(m_fsm->m_PrintHttpLog){
				qTempReq.m_printDbg = true;
			}

			if(!client->Post(qTempReq, qTempRet)){
				if (qTempRet.m_sysCode == 6) {
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_PerTask_HTTP_ERR).setResultCode("RTA5651")("终端查询任务域名解析失败");
				}else if(qTempRet.m_sysCode == 28){
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_PerTask_HTTP_ERR).setResultCode("RTA5652")("终端查询任务连接总行服务超时");
				}else {
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_PerTask_HTTP_ERR).setResultCode("RTA5653")("终端查询任务失败:%s", qTempRet.m_errMsg.c_str());
				}
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_PRE_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewPreTask http req fail,url=%s, err=%s",qTempReq.m_url.c_str(),qTempRet.m_errMsg.c_str()).GetData());
				return false;//失败
			}

			//打印回应报文
			if(m_fsm->m_PrintHttpLog){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryNewPreTaskImpl")("qTempRet=%s",qTempRet.m_retStr.c_str());
			}

			Json::Reader reader;
			Json::Value rootRet;
			if (!reader.parse(qTempRet.m_retStr, rootRet, false)){
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_PRE_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewPreTask parse resp is fail,url=%s",qTempReq.m_url.c_str()).GetData());
				return false;//失败
			}

			bool isSucc = rootRet["success"].asBool();
			if(isSucc){
				if(rootRet.isMember("data")){
					//解析任务，可能不存在任务
					if(rootRet["data"]["task_id"].asString()!=""){
						m_fsm->m_strPreTaskId = rootRet["data"]["task_id"].asString().c_str();
						int need_hash =  rootRet["data"]["need_hash"].asInt();
						if(need_hash==0){
							m_fsm->m_bNeedHash = false;
						}else{
							m_fsm->m_bNeedHash = true;
						}
						return true;//查询成功
					}else{
						//无任务
						m_fsm->m_strPreTaskId = "";
						m_fsm->m_bNeedHash =false;
						return true;//查询成功
					}
				}else{
					LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_PRE_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewPreTask return [data] is null, retry once again ,url=%s",qTempReq.m_url.c_str()).GetData());
					return false;//查询失败
				}
			}else{
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_PRE_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewPreTask [success] is false, retry once again ,url=%s",qTempReq.m_url.c_str()).GetData());
				return false;//查询失败
			}
		}
	};

	//继续查询新任务
	struct QueryNewContinueTask : public ITaskSp{
		CUpgradeTaskFSM* m_fsm;
		explicit QueryNewContinueTask(CUpgradeTaskFSM* f) : m_fsm(f) {}
		void Process(){
			LOG_FUNCTION();
			IHttpFunc* client;
			client = create_http(m_fsm->HttpsLogCallBack);
			//查询新任务
			int retParm=QueryNewContinueTaskImpl(client);
			client->Destory();
			m_fsm->PostEventFIFO(new CUpgradeTaskFSM::QueryNewContinueTaskEvent(retParm));//返回处理结果
		}
		// 0:重试 1:成功 2:跳出
		int QueryNewContinueTaskImpl(IHttpFunc* client){
			HttpStruct::QueryNewTaskReq qTempReq;
			HttpStruct::QueryNewTaskRet qTempRet;

			CSystemStaticInfo info;
			ErrorCodeEnum rc = m_fsm->GetEntityBase()->GetFunction()->GetSystemStaticInfo(info);
			if (rc != Error_Succeed)
			{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryNewContinueTaskImpl")("QueryNewContinueTask get CSystemStaticInfo fail");
				return 0;//查询失败，继续查询
			}
			//机器版本
			CSimpleStringA strMachineVersion = CSimpleStringA::Format("%d.%d",info.MachineVersion.GetMajor(),info.MachineVersion.GetMinor());
			//框架版本
			CSimpleStringA strInstallVersion = m_fsm->m_currentVersion.ToString();
			// OS版本
#ifdef RVC_OS_WIN
			OSVERSIONINFO osvi;    
			ZeroMemory(&osvi, sizeof(OSVERSIONINFO));
			osvi.dwOSVersionInfoSize = sizeof(OSVERSIONINFO);
			GetVersionEx(&osvi);
			CSimpleStringA strOSVersion = CSimpleStringA::Format("%d.%d.%d", osvi.dwMajorVersion, osvi.dwMinorVersion, osvi.dwBuildNumber);
#else
			DWORD dwMajorVersion(0), dwMinorVersion(0), dwBuildNumber(0);
			struct utsname kernel_info;
			int ret = uname(&kernel_info);
			if (ret == 0) {
				int n = sscanf((const char*)kernel_info.release, "%d.%d", &dwMajorVersion, &dwMinorVersion);
			}
			else {
				Dbg("get linux kernel version fail: %s", strerror(errno));
			}
			CSimpleStringA strOSVersion = CSimpleStringA::Format("%d.%d.0", dwMajorVersion, dwMinorVersion);
#endif
			Json::Value rootReq;
			Json::FastWriter writer;
			rootReq["terminal_no"] = info.strTerminalID.GetData();
			rootReq["task_id"] = m_fsm->m_strPreTaskId.GetData();
			rootReq["machine_type"] = info.strMachineType.GetData();
			rootReq["software_version"] = strInstallVersion.GetData();
			rootReq["os_version"] = strOSVersion.GetData();
			rootReq["machine_version"] = strMachineVersion.GetData();
#ifdef RVC_OS_WIN
			rootReq["system_type"] = "W";//表示是windows类型的机器
#else
			rootReq["system_type"] = "L";//表示是uos类型的机器
#endif
			if(m_fsm->m_bNeedHash&&m_fsm->isSendHash){
				//是否发送hash码并且发送成功了
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryNewContinueTaskImpl")("QueryNewContinueTask with hash");
				rootReq["list_hash"] = m_fsm->m_fileSM3ListHash.GetData();
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryNewContinueTaskImpl")("QueryNewContinueTask with no hash");
				rootReq["list_hash"] = "";
			}


			string jsonReq = writer.write(rootReq);
			qTempReq.m_reqStr = jsonReq;//请求参数
			qTempReq.m_url=m_fsm->m_centerUrl.queryContinueTaskUrl;//访问地址

			//打印发送请求
			if(m_fsm->m_PrintHttpLog){
				qTempReq.m_printDbg = true;
			}

			if(!client->Post(qTempReq, qTempRet)){
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_CONTINUE_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewContinueTask http req fail,url=%s, err=%s",qTempReq.m_url.c_str(),qTempRet.m_errMsg.c_str()).GetData());
				return 0;//查询失败，继续查询
			}

			//打印回应报文
			if(m_fsm->m_PrintHttpLog){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryNewContinueTaskImpl")("qTempRet=%s",qTempRet.m_retStr.c_str());
			}

			Json::Reader reader;
			Json::Value rootRet;
			if (!reader.parse(qTempRet.m_retStr, rootRet, false))
			{
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_CONTINUE_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewContinueTask parse resp is fail,url=%s",qTempReq.m_url.c_str()).GetData());
				return 0;//查询失败，继续查询
			}

			bool isSucc = rootRet["success"].asBool();
			if(isSucc){
				if(rootRet.isMember("data")){
					//解析任务，可能不存在任务，task_id为空，则表示无此任务。
					if(rootRet["data"]["task_id"].asString()!=""){
						//task_status 0-无效 1-有效 2-对比不通过 3-hash内容为空
						int task_status = rootRet["data"]["task_status"].asInt();
						if(task_status ==1){
							//pack_status 0-准备中 1-已就绪
							int status = rootRet["data"]["pack_status"].asInt();
							if(status == 1){
								if(!ParamCheck(rootRet)){
									LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_CONTINUE_NEW_TASK_ERR,CSimpleStringA::Format("QueryNewContinueTask paramCheck is fail, check out server exception ,url=%s",qTempReq.m_url.c_str()).GetData());
									return 0;//查询失败 升级任务参数效验失败，告警码不同
								}else{
									m_fsm->m_currentTask.upgradeTaskId = rootRet["data"]["task_id"].asString().c_str();
									m_fsm->m_currentTask.pack_name = rootRet["data"]["pack_name"].asString().c_str();
									m_fsm->m_currentTask.file_path = rootRet["data"]["file_path"].asString().c_str();
									m_fsm->m_currentTask.download_url = rootRet["data"]["download_url"].asString().c_str();
									m_fsm->m_currentTask.pack_hash = rootRet["data"]["pack_hash"].asString().c_str();
									m_fsm->m_currentTask.pack_length = (long)rootRet["data"]["pack_length"].asInt();
									m_fsm->m_currentTask.pack_version = rootRet["data"]["pack_version"].asString().c_str();
									m_fsm->m_currentTask.reboot_type = rootRet["data"]["reboot_type"].asInt();
									m_fsm->m_currentTask.stop_media_play = rootRet["data"]["stop_media_play"].asBool();

									//解析step json
									if(!ParseInstallStep(rootRet)){
										m_fsm->ClearInstallStep();
										LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_CONTINUE_NEW_TASK_ERR,CSimpleStringA::Format("QueryNewContinueTask ParseInstallStep is fail, check out server exception ,url=%s",qTempReq.m_url.c_str()).GetData());
										return 0;//查询失败 解析安装步骤失败，告警码不同
									}

									m_fsm->m_currentTask.createTaskVersion = m_fsm->m_currentVersion.ToString();//新策略，查询到包后，用当前版本值赋值
									DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryNewContinueTaskImpl")("new task id =%s",m_fsm->m_currentTask.upgradeTaskId.GetData());
									return 1;//查询成功
								}	
							}else{
								//任务未准备好
								DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryNewContinueTaskImpl")("QueryNewContinueTask query pack is not create ,please next query,status=%d",status);
								m_fsm->m_currentTask.upgradeTaskId = "";
								return 0;//查询成功，继续查询
							}	
						}else{
							//任务状态无效，对比不通过，hash内容为空
							LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_CONTINUE_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewContinueTask query fail ,task_status=%d",task_status).GetData());
							return 2;//查询成功，但任务不再，跳出来
						}
			
					}else{
						//返回任务为空
						LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_CONTINUE_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewContinueTask return [task id] is null").GetData());
						return 2;//查询成功，但任务不再，跳出来
					}
				}else{
					LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_CONTINUE_NEW_TASK_ERR,CSimpleStringA::Format("QueryNewContinueTask return [data] is null, check out server exception ,url=%s",qTempReq.m_url.c_str()).GetData());
					return 0;//查询失败，继续查询，告警码不同
				}
			}else{
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_CONTINUE_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewContinueTask [success] is false, retry once again ,url=%s",qTempReq.m_url.c_str()).GetData());
				return 0;//查询失败，继续查询
			}
		}

		bool ParamCheck(Json::Value rootRet){

			CSimpleStringA upgradeTaskIdStr = rootRet["data"]["task_id"].asString().c_str();
			if(upgradeTaskIdStr.IsNullOrEmpty()){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryNewContinueTask paramCheck [task_id] is null");
				return false;
			}
			CSimpleStringA packNameStr = rootRet["data"]["pack_name"].asString().c_str();
			if(packNameStr.IsNullOrEmpty()){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryNewContinueTask paramCheck [pack_name] is null");
				return false;
			}
			CSimpleStringA filePathStr = rootRet["data"]["file_path"].asString().c_str();
			if(filePathStr.IsNullOrEmpty()){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryNewContinueTask paramCheck [file_path] is null");
				return false;
			}
			CSimpleStringA downloadUrlStr = rootRet["data"]["download_url"].asString().c_str();
			if(downloadUrlStr.IsNullOrEmpty()){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryNewContinueTask paramCheck [download_url] is null");
				return false;
			}
			CSimpleStringA packHashStr = rootRet["data"]["pack_hash"].asString().c_str();
			if(packHashStr.IsNullOrEmpty()){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryNewContinueTask paramCheck [pack_hash] is null");
				return false;
			}
			long  packLengthStr = (long)rootRet["data"]["pack_length"].asInt();
			

			int rebootTypeInt = rootRet["data"]["reboot_type"].asInt();
			if(rebootTypeInt!=1 && rebootTypeInt!=2  && rebootTypeInt!=0){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryNewContinueTask paramCheck [reboot_type] is invalid ,reboot_type=%d",rebootTypeInt);
				return false;
			}

			CSimpleStringA packVersionStr = rootRet["data"]["pack_version"].asString().c_str();
			if(!packVersionStr.IsNullOrEmpty()){
				int rebootType = rootRet["data"]["reboot_type"].asInt();
				if(rebootType == 1 || rebootType == 2){
					return true;
				}else{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParamCheck")("QueryNewContinueTask paramCheck [pack_version] is not null ,[reboot_type] is not equal 1 or 2");
					return false;
				}
			}
			return true;
		}

		bool ParseInstallStep(Json::Value rootRet){
			//清理以前的遗留的安装步骤
			m_fsm->ClearInstallStep();

			string cmdstr = rootRet["data"]["cmd"].asString();
			if(cmdstr.empty()){
				return true;//为空则直接不解析
			}
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("cmdstr =%s",cmdstr.c_str());

			Json::Reader reader;
			Json::Value InstallRet;
			if (!reader.parse(cmdstr, InstallRet, false))
			{
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_CONTINUE_NEW_TASK_FAIL,CSimpleStringA::Format("QueryNewContinueTask parse cmd fail,cmdstr=%s",cmdstr.c_str()).GetData());
				return false;//解析失败
			}
			for(int i=0;i<InstallRet.size();i++){

				if(!InstallRet[i]["seq"].isInt()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewContinueTask ParseInstallStep [cmd][seq] is not int");
					return false;
				}
				int stepSeq =  InstallRet[i]["seq"].asInt();
				
				if(!InstallRet[i]["cmdType"].isString()&&!InstallRet[i]["cmdType"].isNull()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewContinueTask ParseInstallStep [cmd][cmdType] is not string");
					return false;
				}
				CSimpleStringA cmdType =  InstallRet[i]["cmdType"].asString().c_str();
				if(cmdType.IsNullOrEmpty()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewContinueTask ParseInstallStep [cmd][cmdType] is null");
					return false;
				}
				

				if(!InstallRet[i]["cmdFail"].isInt()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewContinueTask ParseInstallStep [cmd][cmdFail] is not int");
					return false;
				}
				int cmdFail =  InstallRet[i]["cmdFail"].asInt();
				

				if(!InstallRet[i]["srcPathType"].isString()&&!InstallRet[i]["srcPathType"].isNull()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewContinueTask ParseInstallStep [cmd][srcPathType] is not string");
					return false;
				}
				CSimpleStringA srcPathType =  InstallRet[i]["srcPathType"].asString().c_str();
				if(cmdType=="Copy"){
					//复制指令时，不为空
					if(srcPathType.IsNullOrEmpty()){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewContinueTask ParseInstallStep [cmd][srcPathType] is null");
						return false;
					}
				}
				

				if(!InstallRet[i]["srcPath"].isString()&&!InstallRet[i]["srcPath"].isNull()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewContinueTask ParseInstallStep [cmd][srcPath] is not string");
					return false;
				}
				CSimpleStringA srcPath =  InstallRet[i]["srcPath"].asString().c_str();
				if(cmdType=="Copy"){
					//复制指令时，不为空
					if(srcPath.IsNullOrEmpty()){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewContinueTask ParseInstallStep [cmd][srcPath] is null");
						return false;
					}
				}
				

				if(!InstallRet[i]["dstPathType"].isString()&&!InstallRet[i]["dstPathType"].isNull()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewContinueTask ParseInstallStep [cmd][dstPathType] is not string");
					return false;
				}
				CSimpleStringA dstPathType =  InstallRet[i]["dstPathType"].asString().c_str();
				if(cmdType=="Copy"||cmdType=="Delete"||cmdType=="Run"){
					if(dstPathType.IsNullOrEmpty()){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewContinueTask ParseInstallStep [cmd][dstPathType] is null");
						return false;
					}
				}
				

				if(!InstallRet[i]["dstPath"].isString()&&!InstallRet[i]["dstPath"].isNull()){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewContinueTask ParseInstallStep [cmd][dstPath] is not string");
					return false;
				}
				CSimpleStringA dstPath =  InstallRet[i]["dstPath"].asString().c_str();
				if(cmdType=="Delete"||cmdType=="Run"){
					if(dstPath.IsNullOrEmpty()){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("QueryNewContinueTask ParseInstallStep [cmd][dstPath] is null");
						return false;
					}
				}
				

				CUpgradeTaskFSM::CInstallStep* iStep= new CUpgradeTaskFSM::CInstallStep();
				iStep->stepSeq = stepSeq;
				iStep->cmdType = cmdType;
				iStep->cmdFail = cmdFail;
				iStep->srcPathType = srcPathType;
				iStep->srcPath = srcPath;
				iStep->dstPathType =dstPathType;
				iStep->dstPath =dstPath;
				m_fsm->m_currentTask.install_step.push(iStep);//加入队尾
			}
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ParseInstallStep")("install cmd size = %d",InstallRet.size());
			return true;

		}
	};

	//查询任务状态
	struct QueryTaskStatus : public ITaskSp{
		CUpgradeTaskFSM* m_fsm;
		explicit QueryTaskStatus(CUpgradeTaskFSM* f) : m_fsm(f) {}
		void Process(){
			//LOG_FUNCTION();
			IHttpFunc* client;
			client = create_http(m_fsm->HttpsLogCallBack);
			//查询新任务
			bool isSendSucc=false;////查询是否成功标志
			bool isValid=false;//任务是否有效
			if(QueryTaskStatusImpl(client,isValid)){
				isSendSucc = true;
			}else{
				isSendSucc = false;
			}

			client->Destory();
			m_fsm->PostEventFIFO(new CUpgradeTaskFSM::QueryTaskStatusEvent(isSendSucc,isValid));//返回处理结果
		}

		bool QueryTaskStatusImpl(IHttpFunc* client,bool &isValid){
			HttpStruct::QueryCurrTaskReq qTempReq;
			HttpStruct::QueryCurrTaskRet qTempRet;

			CSystemStaticInfo info;
			ErrorCodeEnum rc = m_fsm->GetEntityBase()->GetFunction()->GetSystemStaticInfo(info);
			if (rc != Error_Succeed)
			{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryTaskStatusImpl")("QueryTaskStatus get CSystemStaticInfo fail");
				return false;
			}
			
			Json::Value rootReq;
			Json::FastWriter writer;
			rootReq["terminal_no"] = info.strTerminalID.GetData();
			rootReq["task_id"] = m_fsm->m_currentTask.upgradeTaskId.GetData();

			string jsonReq = writer.write(rootReq);
			qTempReq.m_reqStr = jsonReq;//请求参数
			qTempReq.m_url=m_fsm->m_centerUrl.queryTaskStatus;//访问地址

			//打印发送请求
			if(m_fsm->m_PrintHttpLog){
				qTempReq.m_printDbg = true;
			}

			if(!client->Post(qTempReq, qTempRet)){
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_TASK_STATUS_FAIL,CSimpleStringA::Format("QueryTaskStatus http req fail,upgradeTaskId=%s, url=%s, err=%s",m_fsm->m_currentTask.upgradeTaskId.GetData(), qTempReq.m_url.c_str(), qTempRet.m_errMsg.c_str()).GetData());
				return false;//失败
			}

			//打印回应报文
			if(m_fsm->m_PrintHttpLog){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryTaskStatusImpl")("qTempRet=%s",qTempRet.m_retStr.c_str());
			}

			Json::Reader reader;
			Json::Value rootRet;
			if (!reader.parse(qTempRet.m_retStr, rootRet, false))
			{
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_QUERY_TASK_STATUS_FAIL,CSimpleStringA::Format("QueryTaskStatus parse resp is fail,upgradeTaskId=%s, url=%s",m_fsm->m_currentTask.upgradeTaskId.GetData(), qTempReq.m_url.c_str()).GetData());
				return false;//失败
			}

			bool isSucc = rootRet["success"].asBool();
			if(isSucc){
				if(rootRet.isMember("data")){
					isValid =rootRet["data"].asBool();
					return true;//查询成功
				}else{
					return false;//查询失败
				}
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryTaskStatusImpl")("QueryTaskStatus [success] is false");
				return false;//查询失败
			}
		}
	};

	//下载升级包
	struct DownloadPackTask : public ITaskSp{
		CUpgradeTaskFSM* m_fsm;
		explicit DownloadPackTask(CUpgradeTaskFSM* f) : m_fsm(f) {}
		void Process(){
			LOG_FUNCTION();
			//下载升级包
			if(m_fsm->m_currentTask.pack_name.IsNullOrEmpty()||m_fsm->m_currentTask.pack_hash.IsNullOrEmpty()){
				string errMsg = CSimpleStringA::Format("DownloadPackTask fail,pack_name or pack_hash is null,upgradeTaskId=%s",m_fsm->m_currentTask.upgradeTaskId.GetData()).GetData();
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_DOWNLOAD_PACK_FAIL,errMsg.c_str());
				m_fsm->PostEventFIFO(new CUpgradeTaskFSM::DownloadPackTaskFailEvent(errMsg));//下载失败，返回结果，这种情况下无法继续下载
				return;
			}
			CSimpleStringA dPackName = m_fsm->m_currentTask.pack_name;
			CSimpleStringA dPakchash = m_fsm->m_currentTask.pack_hash;
			long lpacklen = m_fsm->m_currentTask.pack_length;
			
			//判断是否已经下载完成
			CSimpleStringA strPath;
			ErrorCodeEnum rc = m_fsm->GetEntityBase()->GetFunction()->GetPath("Downloads", strPath);
			if(Error_Succeed != rc){
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_DOWNLOAD_PACK_FAIL,CSimpleStringA::Format("DownloadPackTask get Downloads path fail,upgradeTaskId=%s",m_fsm->m_currentTask.upgradeTaskId.GetData()).GetData());
				m_fsm->PostEventFIFO(new CUpgradeTaskFSM::DownloadPackTaskEvent(false));//返回失败结果
				return;
			}
			CSimpleStringA strZipFile = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s", strPath.GetData(), dPackName.GetData());

			if(m_fsm->IsPackDownloaded(strZipFile.GetData(),dPakchash.GetData(),lpacklen)){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadPackTask")("download pack [%s] sm3[%s] is exist ,do not download.", strZipFile.GetData(),dPakchash.GetData());
				m_fsm->PostEventFIFO(new CUpgradeTaskFSM::DownloadPackTaskEvent(true));//下载完成,返回成功结果
				return;
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadPackTask")("download pack [%s] sm3[%s] is not exist ,prepare download.", strZipFile.GetData(),dPakchash.GetData());
			}
			//提前判断是否任务取消
			if(m_fsm->m_bTaskCancel){
				m_fsm->PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_CancelTask));//取消下载任务，返回结果
				return;
			}
			if(m_fsm->m_bDownloadIdle){
				m_fsm->PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_Download_Idle));//下载中断，返回结果
				return;
			}

			//接着下载未完成的升级包
			IHttpFunc* client;
			client = create_http(m_fsm->HttpsLogCallBack);

			bool isDownloadSucc=false;//是否下载成功
			CSimpleStringA errMsg ;//下载失败错误信息
			int ret = DownloadPack(client,strZipFile.GetData(),dPakchash,errMsg);
			if(ret==0){
				m_fsm->PostEventFIFO(new CUpgradeTaskFSM::DownloadPackTaskEvent(false));//返回通讯失败结果
			}else if(ret ==1){
				m_fsm->PostEventFIFO(new CUpgradeTaskFSM::DownloadPackTaskEvent(true));//返回成功结果
			}else if(ret ==2){
				m_fsm->PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_Download_Idle));//下载中断，返回结果
			}else if(ret ==3){
				m_fsm->PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_CancelTask));//取消下载任务，返回结果
			}else if(ret ==4){
				m_fsm->PostEventFIFO(new CUpgradeTaskFSM::DownloadPackTaskFailEvent(errMsg.GetData()));//下载失败，任务中止
			}
			client->Destory();
		}

		//返回值 0：下载通讯失败 1：下载成功 2：下载中断 3：任务取消 4：下载失败
		int DownloadPack(IHttpFunc* client,const char* dPackPath,const char* dPackHash,CSimpleStringA &errMsg){
			bool isDownloadSucc = false;
			CSimpleStringA dPackPathTemp = CSimpleStringA::Format("%s%s",dPackPath,".tmp");//默认临时文件是.tmp后缀

			long dPackTempLen = 0;
			if(ExistsFileA(dPackPathTemp)){
				if(!m_fsm->GetFileLength(dPackPathTemp.GetData(),dPackTempLen)){
					LogWarn(Severity_Middle, Error_Exception, ERR_TASK_DOWNLOAD_PACK_FAIL,CSimpleStringA::Format("%s get download temp pack fileLen is fail", dPackPathTemp.GetData()).GetData());
					errMsg = "get download temp pack fileLen is fail";
					return 4;//下载失败，计算临时文件长度失败
				}
			}
			byte* content = new byte[m_fsm->m_newEachDownloadLen];
			memset(content, 0, m_fsm->m_newEachDownloadLen);
			bool isContinue = true;
			while(isContinue){
				if(m_fsm->m_bTaskCancel){
					//任务取消
					delete[] content;
					return 3;
				}
				if(m_fsm->m_bDownloadIdle){
					//状态中断
					delete[] content;
					return 2;
				}
				HttpStruct::DownloadPackTaskRet resp;
				resp.bfinish= false;//默认是未下载完
				resp.sm3 = "";//默认是空串
				if(DownloadPackTaskImpl(client,dPackTempLen,content,resp)){
					//DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadPack")("download succ, %d , begin write %d",(int)resp.bfinish,dPackTempLen);
					//成功通讯
					if(!m_fsm->DownloadFileWrite(content,resp.content_length,dPackPathTemp)){
						LogWarn(Severity_Middle, Error_Exception, ERR_TASK_DOWNLOAD_PACK_FAIL,CSimpleStringA::Format("DownloadFileWrite write temp file fail,begin write=%d, write len=%d", dPackTempLen,resp.content_length).GetData());
						errMsg = "DownloadFileWrite write temp file fail";
						delete[] content;
						return 4;//下载失败，写文件失败
					}else{
						m_fsm->DownloadProgress(dPackTempLen+resp.content_length,resp.origin_file_length);//广播下载进度
					}
					if(resp.bfinish){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadPack")("最后一次下载");
						//最后一次
						CSimpleStringA strMD5Val;
						ErrorCodeEnum rc = m_fsm->SM3FileToStr(dPackPathTemp, strMD5Val,false);
						if (Error_Succeed != rc)
						{
							LogWarn(Severity_Middle, Error_Exception, ERR_TASK_DOWNLOAD_PACK_FAIL,CSimpleStringA::Format("%s get download temp pack sm3 fail ,error:%d", dPackPathTemp.GetData(), (int)rc).GetData());
							errMsg = "get download temp pack sm3 fail";
							delete[] content;
							return 4;//下载失败，算hash失败
						}
						//不区分大小写比较文件hash
#ifdef RVC_OS_WIN
						if(stricmp(strMD5Val.GetData(),resp.sm3.c_str())==0){
#else
						if(strcmp(strMD5Val.GetData(),resp.sm3.c_str())==0){
#endif						
							//移动文件到正式目录
							if(ExistsFileA(dPackPath)){
								if(remove(dPackPath)==0){
									DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadPack")("delete download old pack succ ", dPackPath);
									if(rename(dPackPathTemp.GetData(),dPackPath)!=0){
#ifdef RVC_OS_WIN
										errMsg = CSimpleStringA::Format("exist old file,remove temp file fail, error=%d",(int)GetLastError()).GetData();
#else
										errMsg = CSimpleStringA::Format("exist old file,remove temp file fail, error=%d", errno).GetData();
#endif										
										LogWarn(Severity_Middle, Error_Exception, ERR_TASK_DOWNLOAD_PACK_FAIL,errMsg.GetData());
										delete[] content;
										return 4;//下载失败，移动文件失败
									}else{
										delete[] content;
										return 1;//成功返回
									}
								}else{
#ifdef RVC_OS_WIN
									errMsg = CSimpleStringA::Format("delete download old pack fail ,error:%d",(int)GetLastError()).GetData();
#else
									errMsg = CSimpleStringA::Format("delete download old pack fail ,error:%d", errno).GetData();
#endif
									LogWarn(Severity_Middle, Error_Exception, ERR_TASK_DOWNLOAD_PACK_FAIL,errMsg.GetData());
									delete[] content;
									return 4;//下载失败，删除旧文件失败
								}
							}else{
								if(rename(dPackPathTemp.GetData(),dPackPath)!=0){
#ifdef RVC_OS_WIN
									errMsg = CSimpleStringA::Format("not exist old file,remove temp file fail, error=%d",(int)GetLastError()).GetData();
#else
									errMsg = CSimpleStringA::Format("not exist old file,remove temp file fail, error=%d", errno).GetData();
#endif
									LogWarn(Severity_Middle, Error_Exception, ERR_TASK_DOWNLOAD_PACK_FAIL,errMsg.GetData());
									delete[] content;
									return 4;//移动文件失败
								}else{
									delete[] content;
									return 1;//成功返回
								}
							}
						}else{
							errMsg = CSimpleStringA::Format("download file sm3 is not equal,local file [%s],resp [%s]",strMD5Val.GetData(),resp.sm3.c_str()).GetData();
							LogWarn(Severity_Middle, Error_Exception, ERR_TASK_DOWNLOAD_PACK_FAIL,CSimpleStringA::Format("download file sm3 is not equal,local file [%s],resp [%s]",strMD5Val.GetData(),resp.sm3.c_str()).GetData());
							//删除临时文件，重新下载
							if(remove(dPackPathTemp.GetData())==0){
								DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadPack")("delete download temp pack succ ,%s", dPackPathTemp.GetData());
							}else{
#ifdef RVC_OS_WIN							
								DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadPack")("delete download temp pack fail ,%s  error:%d", dPackPathTemp.GetData(), GetLastError());
#else
								DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadPack")("delete download temp pack fail ,%s  error:%d", dPackPathTemp.GetData(), errno);
#endif								
							}
							delete[] content;
							return 4;//下载失败，hash不对
						}
					}else{

						if(resp.content_length==0){
							errMsg = "DownloadFile server content_length = 0 ,bfinish = false ,DownloadFile server return param fail";
							LogWarn(Severity_Middle, Error_Exception, ERR_TASK_DOWNLOAD_PACK_FAIL,"DownloadFile server content_length = 0 ,bfinish = false ,DownloadFile server return param fail");
							delete[] content;
							return 4;//传回零字节，但是又未结束，下载失败，等待一段时间下载
						}
						//继续下一次续传
						dPackTempLen =dPackTempLen+resp.content_length;
						memset(content, 0, m_fsm->m_newEachDownloadLen);
						isContinue = true;
					}
				}else{
					delete[] content;
					return 0;//下载通讯失败,等待一段时间下载
				}
			}

		}

		bool DownloadPackTaskImpl(IHttpFunc* client,long downloaded_len,byte* respContent,HttpStruct::DownloadPackTaskRet &resp){
			//注意传入参数和传出参数进行转码
			CSystemStaticInfo info;
			ErrorCodeEnum rc = m_fsm->GetEntityBase()->GetFunction()->GetSystemStaticInfo(info);
			if (rc != Error_Succeed)
			{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadPackTaskImpl")("DownloadPackTask get CSystemStaticInfo fail");
				return false;//失败
			}

			Json::Value rootReq;
			Json::FastWriter writer;
			rootReq["terminal_no"] = info.strTerminalID.GetData();
			rootReq["pack_name"] = m_fsm->m_currentTask.pack_name.GetData();
			rootReq["downloaded_length"] = downloaded_len;
			rootReq["limit_length"] = m_fsm->m_newEachDownloadLen;
			rootReq["file_path"] = m_fsm->m_currentTask.file_path.GetData();

			string jsonReq = writer.write(rootReq);
			CSimpleStringA downloadUrl = m_fsm->m_currentTask.download_url;
			//转码
			m_fsm->ConvertGBKToUtf8(jsonReq);

			//打印发送请求
			if(m_fsm->m_PrintHttpLog){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadPackTaskImpl")("jsonStr is %s",jsonReq.c_str());
			}

			long httpCode =0;
			unordered_map<string, string> responseHeaders;
			int time_out = DOWNLOAD_TIMEOUT;
			if(!client->DownloadFileBlock(downloadUrl.GetData(),jsonReq.c_str(),respContent,httpCode,responseHeaders,time_out)){
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_DOWNLOAD_PACK_FAIL,CSimpleStringA::Format("DownloadPackTask http req fail,url=%s",downloadUrl.GetData()).GetData());
				return false;//失败
			}
			//判断httpCode
			if(httpCode!=200){
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_DOWNLOAD_PACK_FAIL,CSimpleStringA::Format("DownloadPackTask http req fail, url=%s, retHttpCode=%d",downloadUrl.GetData(),httpCode).GetData());
				return false;//失败
			}
			//解析head值
			unordered_map<string, string>::const_iterator iter  = responseHeaders.find("Result");
			if(iter==responseHeaders.end()){
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_DOWNLOAD_PACK_FAIL,"resp head result is null");
				return false;//无params 失败
			}else{
				string respStr = iter->second;
				//转码：
				m_fsm->ConvertUtf8ToGBK(respStr);

				//打印回应报文
				if(m_fsm->m_PrintHttpLog){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadPackTaskImpl")("qTempRet Result=%s",respStr.c_str());
				}

				//解析json值
				Json::Reader reader;
				Json::Value rootRet;
				if (!reader.parse(respStr, rootRet, false))
				{
					LogWarn(Severity_Middle, Error_Exception, ERR_TASK_DOWNLOAD_PACK_FAIL,"DownloadPackTask head params parse resp is fail");
					return false;//解析失败
				}
				bool isSucc = rootRet["success"].asBool();
				if(isSucc){
					resp.content_length = (long)rootRet["content_length"].asInt();
					resp.origin_file_length = (long)rootRet["origin_file_length"].asInt();
					resp.bfinish = rootRet["finish"].asBool();//是否传送完毕
					resp.sm3 = rootRet["sm3"].asString();//包hash码
					return true;//查询成功
				}else{
					CSimpleStringA msg = rootRet["message"].asString().c_str();
					if(msg.IsNullOrEmpty()){
						msg = "";
					}
					LogWarn(Severity_Middle, Error_Exception, ERR_TASK_DOWNLOAD_PACK_FAIL,CSimpleStringA::Format("DownloadPackTask [success] is false, err=%s",msg.GetData()).GetData());
					return false;//查询失败
				}
			}
		}
	};

	//停止播放广告和提示音
	struct StopMediaPlayTask : public ITaskSp{
		CUpgradeTaskFSM* m_fsm;
		explicit StopMediaPlayTask(CUpgradeTaskFSM* f) : m_fsm(f) {}
		void Process(){
			LOG_FUNCTION();
			//判断是否需要停止广播和提示音
			if(!m_fsm->m_currentTask.stop_media_play){
				m_fsm->PostEventFIFO(new CUpgradeTaskFSM::StopMediaPlayTaskEvent(true));//返回处理结果
			}else{
				//停止广告、提示音播放
				// 终端置为升级状态。1:升级状态，0：非升级状态。处于升级状态时调用播放接口不生效
				ErrorCodeEnum rc = ((CUpgradeMgrEntity*)m_fsm->GetEntityBase())->NewStopMediaPlay();
				if(rc==Error_Succeed){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("StopMediaPlayTask")("StopMediaPlayTask stop media play succ");
				}else{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("StopMediaPlayTask")("StopMediaPlayTask stop media play fail");
					//m_fsm->PostEventFIFO(new CUpgradeTaskFSM::StopMediaPlayTaskEvent(false));//返回处理结果
				}
				// 终端置为升级状态。1:升级状态，0：非升级状态。处于升级状态时调用播放接口不生效

				rc = m_fsm->GetEntityBase()->GetFunction()->SetSysVar("UpdateState", "1", false);
				if(rc==Error_Succeed){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("StopMediaPlayTask")("StopMediaPlayTask set UpdateState to 1 succ");
				}else{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("StopMediaPlayTask")("StopMediaPlayTask set UpdateState to 1 fail");
					m_fsm->PostEventFIFO(new CUpgradeTaskFSM::StopMediaPlayTaskEvent(false));//返回处理结果
					return;
				}
				m_fsm->PostEventFIFO(new CUpgradeTaskFSM::StopMediaPlayTaskEvent(true));//返回处理结果
			}
		}
	};	

	//解压安装包
	struct UnzipPackTask : public ITaskSp{
		CUpgradeTaskFSM* m_fsm;
		explicit UnzipPackTask(CUpgradeTaskFSM* f) : m_fsm(f) {}
		void Process(){
			LOG_FUNCTION();
			//解压安装包
			bool isUnzipSucc;//是否解压成功
			if(m_fsm->UnzipPack(m_fsm->m_currentTask.pack_name.GetData())==Error_Succeed){
				isUnzipSucc = true;
			}else{
				isUnzipSucc = false;
			}

			m_fsm->PostEventFIFO(new CUpgradeTaskFSM::UnzipPackTaskEvent(isUnzipSucc));//返回处理结果
		}
	};	

	//升级包安装
	struct InstallPackTask : public ITaskSp{
		CUpgradeTaskFSM* m_fsm;
		explicit InstallPackTask(CUpgradeTaskFSM* f) : m_fsm(f) {}
		void Process(){
			LOG_FUNCTION();
			//升级包安装
			bool isInstallSucc=false;//是否安装成功
			int  failStatus=0;//安装失败状态：0:失败，1：成功，-1:未知  
			string packName = m_fsm->m_currentTask.pack_name.GetData();
			CSimpleStringA errMsg ="";
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("InstallPackTask")("======begin ExecInstall======");
			failStatus = m_fsm->ExecInstall(errMsg);

			if(failStatus == 1){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("InstallPackTask")("======end ExecInstall:succ======");
				isInstallSucc =true;
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("InstallPackTask")("======end ExecInstall:fail======");
				isInstallSucc =false;
			}
			//清理临时解压包
			if(Error_Succeed==m_fsm->DeleteUnzipDir()){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("InstallPackTask")("DeleteUnzipDir succ");
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("InstallPackTask")("DeleteUnzipDir fail");
			}

			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("InstallPackTask")("安装完成：failStatus=%d",failStatus);
			m_fsm->PostEventFIFO(new CUpgradeTaskFSM::InstallPackTaskEvent(isInstallSucc,errMsg,failStatus));//返回处理结果
		}
	};	


}

//完成
// 创建新版本目录，拷贝当前版本bin、cfg、dep、mod、imdep、res、install.ini，并修改Shell.ini相关配置
ErrorCodeEnum CUpgradeTaskFSM::CreateNewVersion(CVersion NewSoftwareVersion,CSimpleStringA &strErrInfo)
{
	// 创建安装包日志文件

	CSimpleStringA rootVerPath;
	ErrorCodeEnum rc = m_pEntity->GetFunction()->GetPath("RootVer",rootVerPath);//获取version根路径
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("Create new version fail , get RootVer path is fail");
		strErrInfo = CSimpleStringA::Format("Create new version fail , get RootVer path is fail");
		return Error_Bug;
	}
	CSimpleStringA strCurVerPath;
	rc = m_pEntity->GetFunction()->GetPath("Base",strCurVerPath);//获取当前version路径
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("Create new version fail , get Base path is fail");
		strErrInfo = CSimpleStringA::Format("Create new version fail , get Base path is fail");
		return Error_Bug;
	}

	CSimpleStringA strNewVerPath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s", rootVerPath.GetData(), NewSoftwareVersion.ToString().GetData());

	//auto &v = cfg->install_ini->install_version;//获取当前版本
	//CVersion v;//获取当前版本
	CVersion curVersion(m_currentVersion.GetMajor(), m_currentVersion.GetMinor(), m_currentVersion.GetRevision(), m_currentVersion.GetBuild());

	if (curVersion == NewSoftwareVersion)
	{
		LogError(Severity_Low, Error_Bug, 0, CSimpleStringA::Format("new ver [%s] equals current ver [%s]", NewSoftwareVersion.ToString().GetData(), curVersion.ToString().GetData()).GetData());
		strErrInfo = CSimpleStringA::Format("new ver [%s] equals current ver [%s]", NewSoftwareVersion.ToString().GetData(), curVersion.ToString().GetData());
		return Error_Bug;
	}

	if (ExistsDirA(strNewVerPath.GetData()))
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("new version dir [%s] already exist, delete it", strNewVerPath.GetData());
		if(!RemoveDirRecursiveA(strNewVerPath.GetData())){
#ifdef RVC_OS_WIN
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("Create new version fail, delete already exist new version is fail:%d",GetLastError());
			strErrInfo = CSimpleStringA::Format("Create new version fail, delete already exist new version is fail:%d",(int)GetLastError());
#else
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("Create new version fail, delete already exist new version is fail:%d", errno);
			strErrInfo = CSimpleStringA::Format("Create new version fail, delete already exist new version is fail:%d", errno);
#endif		
			return Error_Bug;
		}
	}

	if (!CreateDirA(strNewVerPath.GetData(), TRUE))
	{
#ifdef RVC_OS_WIN
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("Create new version dir fail: %d", GetLastError());
		strErrInfo = CSimpleStringA::Format("create new version dir fail: %d", (int)GetLastError());
#else
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("Create new version dir fail: %d", errno);
		strErrInfo = CSimpleStringA::Format("create new version dir fail: %d", errno);
#endif	
		return Error_Unexpect;
	}
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("create new version dir succ, dir = %s",strNewVerPath.GetData());
	//增加错误信息字段，回传给上层应用
	CSimpleStringA strErrMsg ="";

	CSimpleStringA strSource = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "bin", strCurVerPath.GetData());
	CSimpleStringA strDest = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "bin", strNewVerPath.GetData());

	if (!RecursiveCopyDir(strSource, strDest,strErrMsg))
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("copy bin dir fail");
		strErrInfo = CSimpleStringA::Format("copy bin dir fail: %s", strErrMsg.GetData());
		return Error_Unexpect;
	}
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("copy bin dir succ");

	strSource = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "cfg", strCurVerPath.GetData());
	strDest = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "cfg", strNewVerPath.GetData());
	if (!RecursiveCopyDir(strSource, strDest,strErrMsg))
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("copy cfg dir fail");
		strErrInfo = CSimpleStringA::Format("copy cfg dir fail: %s", strErrMsg.GetData());
		return Error_Unexpect;
	}
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("copy cfg dir succ");

	strSource = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "dep", strCurVerPath.GetData());
	strDest = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "dep", strNewVerPath.GetData());
	if (!RecursiveCopyDir(strSource, strDest,strErrMsg))
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("copy dep dir fail");
		strErrInfo = CSimpleStringA::Format("copy dep dir fail: %s", strErrMsg.GetData());
		return Error_Unexpect;
	}
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("copy dep dir succ");

	strSource = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "mod", strCurVerPath.GetData());
	strDest = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "mod", strNewVerPath.GetData());
	if (!RecursiveCopyDir(strSource, strDest,strErrMsg))
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("copy mod dir fail");
		strErrInfo = CSimpleStringA::Format("copy mod dir fail: %s", strErrMsg.GetData());
		return Error_Unexpect;
	}
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("copy mod dir succ");

	strSource = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "res", strCurVerPath.GetData());
	strDest = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "res", strNewVerPath.GetData());

	// 检测res目录是否存在
	if (ExistsDirA(strSource))
	{
		if (!RecursiveCopyDir(strSource, strDest,strErrMsg))
		{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("copy res dir fail");
			strErrInfo = CSimpleStringA::Format("copy res dir fail: %s", strErrMsg.GetData());
			return Error_Unexpect;
		}
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("copy res dir succ");
	}
	else
	{
		if (!CreateDirA(strDest, TRUE))
		{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("create res dir fail");
			strErrInfo = "create res dir fail";
			return Error_Unexpect;
		}
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("create res dir succ");
	}

	strSource = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "imdep", strCurVerPath.GetData());
	strDest = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "imdep", strNewVerPath.GetData());

	// 检测imdep目录是否存在
	if (ExistsDirA(strSource))
	{
		if (!RecursiveCopyDir(strSource, strDest,strErrMsg))
		{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("copy imdep dir fail");
			strErrInfo = CSimpleStringA::Format("copy imdep dir fail: %s", strErrMsg.GetData());
			return Error_Unexpect;
		}
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("copy imdep dir succ");
	}
	else
	{
		if (!CreateDirA(strDest, TRUE))
		{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("create imdep dir fail");
			strErrInfo = "create imdep dir fail";
			return Error_Unexpect;
		}
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CreateNewVersion")("create imdep dir succ");
	}
	return Error_Succeed;
}

ErrorCodeEnum CUpgradeTaskFSM::ClearUpgradeFailVersion(CVersion NewSoftwareVersion)
{
	CSimpleStringA rootVerPath;
	ErrorCodeEnum rc = m_pEntity->GetFunction()->GetPath("RootVer",rootVerPath);//获取version根路径
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ClearUpgradeFailVersion")("ClearUpgradeFailVersion fail , get RootVer path is fail");
		return Error_Bug;
	}
	CSimpleStringA strNewVerPath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s", rootVerPath.GetData(), NewSoftwareVersion.ToString().GetData());
	if (ExistsDirA(strNewVerPath.GetData()))
	{
		if(!RemoveDirRecursiveA(strNewVerPath.GetData())){
#ifdef RVC_OS_WIN
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ClearUpgradeFailVersion")("ClearUpgradeFailVersion fail, delete temp Version [%s] is fail:%d",strNewVerPath.GetData(),(int)GetLastError());
#else
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ClearUpgradeFailVersion")("ClearUpgradeFailVersion fail, delete temp Version [%s] is fail:%d", strNewVerPath.GetData(), errno);
#endif
			return Error_Bug;
		}else{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ClearUpgradeFailVersion")("ClearUpgradeFailVersion succ, delete temp Version [%s] ", strNewVerPath.GetData());
			return Error_Succeed;
		}
	}else{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ClearUpgradeFailVersion")("ClearUpgradeFailVersion succ, delete temp Version [%s] is not exsit ", strNewVerPath.GetData());
		return Error_Succeed;
	}
}


// result.log 文件内容： result=0&msg=install ok
bool CUpgradeTaskFSM::GetSysUpgradeResult(const char *pszResultLog, CSimpleStringA &eErrorCode, CSimpleStringA &strErrMsg)
{
	// 设置初始值
	//eErrorCode = Error_Succeed;
	strErrMsg = "";

	if (!ExistsFileA(pszResultLog))
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetSysUpgradeResult")("GetSysUpgradeResult result log [%s] not exist", pszResultLog);
		strErrMsg = "result.log not exist";
		eErrorCode = "0";
		return true;//???有些外部程序不一定会产生日志文件，故默认不产生文件，认为是成功
	}

	FILE *pResultLog = fopen(pszResultLog, "r");
	if (pResultLog == NULL)
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetSysUpgradeResult")("GetSysUpgradeResult open result log [%s] fail", pszResultLog);
		strErrMsg = "open result.log fail";
		return false;
	}

	char szTmp[4096] = {};
	int nRead = fread_s(szTmp, sizeof(szTmp), 1, sizeof(szTmp), pResultLog);
	CSimpleStringA strResult = szTmp;
	fclose(pResultLog);
	pResultLog = NULL;

	auto arr = strResult.Split('&');
	if(arr.GetCount()!=2){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetSysUpgradeResult")("GetSysUpgradeResult read result log format fail,[%s]", strResult.GetData());
		strErrMsg = "read result.log format fail,eg result=0&msg=install ok";
		return false;
	}
	for (int i = 0; i < arr.GetCount(); i++)
	{
		auto arr2 = arr[i].Split('=');
		if (arr2.GetCount() == 2)
		{
#ifdef RVC_OS_WIN
			if (stricmp(arr2[0], "result") == 0)
				eErrorCode = arr2[1];
			else if (stricmp(arr2[0], "msg") == 0)
				strErrMsg = arr2[1];
#else
			if (strcmp(arr2[0], "result") == 0)
				eErrorCode = arr2[1];
			else if (strcmp(arr2[0], "msg") == 0)
				strErrMsg = arr2[1];
#endif
		}
	}
	return true;
}

int CUpgradeTaskFSM::ExecInstall(CSimpleStringA &strErrMsg)
{

	//判断是否需要生成新版本
	if(!m_currentTask.pack_version.IsNullOrEmpty()){

		CSimpleStringA  strUpgradeVersion = m_currentTask.pack_version;
		CVersion latterVersion;//要更新到的版本号
		CVersion curVer = m_currentVersion;//当前版本号
		// 指定版本
		DWORD dwMajor(0), dwMinor(0), dwRevision(0), dwBuild(0);
		int n = sscanf(strUpgradeVersion.GetData(), "%d.%d.%d.%d", &dwMajor, &dwMinor, &dwRevision, &dwBuild);
		if (n != 4)
		{
			strErrMsg = CSimpleStringA::Format("指定升级版本号无效(%s)", strUpgradeVersion.GetData());
			LogError(Severity_Low, Error_Unexpect, 0, CSimpleStringA::Format("specified software version is invalid: [%s]", strUpgradeVersion.GetData()).GetData());
			return 0;
		}else{
			latterVersion = CVersion(dwMajor, dwMinor, dwRevision, dwBuild);
		}
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecInstall")("latterVersion :%s",latterVersion.ToString().GetData());
		if(curVer.ToString()==strUpgradeVersion){
			//版本号相同，
			strErrMsg = CSimpleStringA::Format("指定升级版本号与当前版本相同,无效(配置:%s, 当前:%s)", strUpgradeVersion.GetData(),curVer.ToString().GetData());
			return 0;
		//}else if(m_currentVersion.ToString().Compare(strUpgradeVersion)==1){
		//字符串比较版本号大小改为整形数字对比
		}else if(dwMajor < curVer.GetMajor() 
			||  (dwMajor == curVer.GetMajor() && dwMinor < curVer.GetMinor())
			||	(dwMajor == curVer.GetMajor() && dwMinor == curVer.GetMinor() && dwRevision < curVer.GetRevision())
			||	(dwMajor == curVer.GetMajor() && dwMinor == curVer.GetMinor() && dwRevision == curVer.GetRevision() && dwBuild < curVer.GetBuild())){
			//升级版本小于当前版本
			strErrMsg = CSimpleStringA::Format("指定升级版本号无效(配置:%s,解析:%s,当前:%s)", strUpgradeVersion.GetData(),latterVersion.ToString().GetData(),curVer.ToString().GetData());
			return 0;
		}

		//判断是否需要创建新版本
		
		CSimpleStringA strErrInfo = "";
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecInstall")("begin CreateNewVersion,version[%s],pack[%s]",strUpgradeVersion.GetData(),m_currentTask.pack_name.GetData());
		ErrorCodeEnum rc = CreateNewVersion(latterVersion,strErrInfo);
		if (rc != Error_Succeed)
		{
			strErrMsg = CSimpleStringA::Format("CreateNewVersion fail:%s",strErrInfo.GetData());
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecInstall")("CreateNewVersion,version[%s] fail:%s",strUpgradeVersion.GetData(),strErrInfo.GetData());
			//清理临时版本文件夹
			ClearUpgradeFailVersion(latterVersion);
			return 0;
		}else{
			m_currentTask.NewVersion = strUpgradeVersion;//赋值升级版本号给内存变量
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecInstall")("CreateNewVersion,version[%s] succ",strUpgradeVersion.GetData());
		}
	}

	//循环执行安装命令
	int iRet=1;//默认是成功
	if(!m_currentTask.install_step.empty()){
		
		int iCount = m_currentTask.install_step.size();
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecInstall")("install cmd size = %d",iCount);
		for (int j = 0; j < iCount; j++){
			CInstallStep* tmp = m_currentTask.install_step.front();
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecInstall")("=====begin cmd=[%s]=====",tmp->cmdType.GetData());
			//开始处理具体命令
			if(tmp->cmdType=="Delete"){
				bool ret = ExecDeleteCmd(strErrMsg,tmp);
				if(!ret){
					//报错才判断
					if(tmp->cmdFail == 0 ){
						iRet = 0;
						break;//出错直接退出
					}else if(tmp->cmdFail == 1 ){
						//继续
					}else{
						iRet = 0;
						break;//其他值也退出
					}
				}

			}else if(tmp->cmdType=="Copy"){

				bool ret = ExecCpoyCmd(strErrMsg,tmp);
				if(!ret){
					//报错才判断
					if(tmp->cmdFail == 0){
						iRet = 0;
						break;//出错直接退出
					}else if(tmp->cmdFail == 1){
						//继续
					}else{
						iRet = 0;
						break;//其他值也退出
					}
				}
			}else if(tmp->cmdType=="Run"){
				int retInt = ExecRunCmd(strErrMsg,tmp);
				if(retInt==0||retInt==-1){
					//报错才判断
					if(tmp->cmdFail == 0 ){
						iRet = retInt;//会有0，-1值
						break;//出错直接退出,并返回体系外结果
					}else if(tmp->cmdFail == 1 ){
						//继续
					}else{
						iRet = 0;
						break;//其他值也退出
					}
				}
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecInstall")("cmd=[%s] is invalid",tmp->cmdType.GetData());
				iRet = 0;
				break;//命令无效直接退出
			}
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecInstall")("=====end cmd=[%s]=====",tmp->cmdType.GetData());
			m_currentTask.install_step.pop();//去除元素
			delete tmp;//删除内存
		}
	}

	return iRet;//返回处理结果
}

int CUpgradeTaskFSM::ExecRunCmd(CSimpleStringA &strErrMsg,CInstallStep* ins)
{
	CSimpleStringA destPath ;//目的路径

	if(ins->dstPathType=="0"){
		CSimpleStringA rootPath;
		if(GetRootTypePath(1,rootPath)){
			destPath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",rootPath.GetData(),ins->dstPath.GetData());//相对路径		
		}else{
			strErrMsg = CSimpleStringA::Format("ExecRunCmd destPath GetRootTypePath 1 is fail");
			return false;
		}
	}else if(ins->dstPathType=="1"){

		destPath = ins->dstPath;//绝对路径

	}else if(ins->dstPathType=="2"){
		CSimpleStringA rootPath;
		if(GetRootTypePath(2,rootPath)){
			destPath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",rootPath.GetData(),ins->dstPath.GetData());//当前版本相对路径
		}else{
			strErrMsg = CSimpleStringA::Format("ExecRunCmd destPath GetRootTypePath 2 is fail");
			return false;
		}

	}else if(ins->dstPathType=="3"){
		CSimpleStringA rootPath;
		if(GetRootTypePath(3,rootPath)){
			destPath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",rootPath.GetData(),ins->dstPath.GetData());//升级版本相对路径
		}else{
			strErrMsg = CSimpleStringA::Format("ExecRunCmd destPath GetRootTypePath 3 is fail");
			return false;
		}
	}else if(ins->dstPathType=="4"){
		CSimpleStringA rootPath;
		if(GetRootTypePath(4,rootPath)){
			destPath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",rootPath.GetData(),ins->dstPath.GetData());//升级包相对路径
		}else{
			strErrMsg = CSimpleStringA::Format("ExecRunCmd destPath GetRootTypePath 4 is fail");
			return false;
		}
	}else{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecRunCmd")("ExecRunCmd destPathType is invalid %s",ins->dstPathType.GetData());
		strErrMsg = CSimpleStringA::Format("ExecRunCmd destPathType is invalid %s",ins->dstPathType.GetData());
		return false;//不支持的路径类型
	}

	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecRunCmd")("ExecRunCmd destPath is %s",destPath.GetData());

	// ToRun=install.bat

	if (ExistsFileA(destPath.GetData()))
	{
#ifdef RVC_OS_WIN
		// window模式下 如果是Wow64模式，需屏蔽System32重定向
		PVOID pRedirectOldValue(NULL);
		bool bIsWow64 = IsWow64Process();
		if (bIsWow64)
		{
			if (!Wow64DisableWow64FsRedirection(&pRedirectOldValue)){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecRunCmd")("Wow64DisableWow64FsRedirection fail: %d", GetLastError());
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecRunCmd")("Wow64DisableWow64FsRedirection succ");
			}
		}
#endif
		//system(strSourcePath);
		string sysPathStr = destPath.GetData();
		CSimpleStringA err ="";
		int ret = system_on(sysPathStr,true,err);
#ifdef RVC_OS_WIN
		// 如果是Wow64模式，恢复System32重定向
		if (bIsWow64)
		{
			if (!Wow64RevertWow64FsRedirection(pRedirectOldValue)){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecRunCmd")("Wow64RevertWow64FsRedirection fail: %d", GetLastError());
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecRunCmd")("Wow64RevertWow64FsRedirection succ");
			}
		}
#endif
		if(ret!=0){
			//程序执行异常,结果未知
#ifdef RVC_OS_WIN
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecRunCmd")("ExecRunCmd is fail, system_on exec unknown ,err=%s",err.GetData());
			strErrMsg = CSimpleStringA::Format("ExecRunCmd is fail, system_on exec unknown ,err=%s",err.GetData());
#else
			DbgWithLink(LOG_LEVEL_ERROR,LOG_TYPE_SYSTEM).setAPI("ExecRunCmd")("ExecRunCmd is fail, system_on exec unknown , ret=%d, err=%s",ret, strerror(errno));
			strErrMsg = CSimpleStringA::Format("ExecRunCmd is fail, system_on exec unknown  ret=%d, err=%s", ret, strerror(errno));
#endif			

			return -1;//未知结果返回

		}else{
			//进一步看返回结果文件判断是否成功
			CSimpleStringA strUnzipPath = GetFileDirectory(destPath.GetData());
#ifdef RVC_OS_WIN
			CSimpleStringA strResultLog = strUnzipPath + "\\result.log";//结果文件
#else
			CSimpleStringA strResultLog = strUnzipPath + "/result.log";//结果文件
#endif
			CSimpleStringA eErrorCode = "";
			//获取结果文件
			if (!GetSysUpgradeResult(strResultLog, eErrorCode, strErrMsg))
			{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecRunCmd")("ExecRunCmd is fail, get result from result.log fail, %s", strErrMsg.GetData());
				strErrMsg = CSimpleStringA::Format("ExecRunCmd is fail ,get result from result.log fail, %s", strErrMsg.GetData());
				return 0;//失败
			}

			if (eErrorCode == "0")
			{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecRunCmd")("ExecRunCmd is succ,[%s] ", destPath.GetData());
				return 1;//成功
			}else{
#ifdef RVC_OS_WIN
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecRunCmd")("ExecRunCmd is fail,errorCode = %s", eErrorCode.GetData());
				strErrMsg = CSimpleStringA::Format("ExecRunCmd is fail,errorCode = %s", eErrorCode.GetData());
#else
				DbgWithLink(LOG_LEVEL_ERROR,LOG_TYPE_SYSTEM).setAPI("ExecRunCmd")("ExecRunCmd is fail,errorCode = %s,%s", eErrorCode.GetData(), strErrMsg.GetData());
				strErrMsg = CSimpleStringA::Format("ExecRunCmd is fail,errorCode = %s,%s", eErrorCode.GetData(), strErrMsg.GetData());
#endif			
				return 0;//失败
			}
		}
	}
	else
	{
		strErrMsg = CSimpleStringA::Format("ExecRunCmd is fail, run file [%s] is not Exist",destPath.GetData());
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecRunCmd")("ExecRunCmd is fail, run file [%s] is not Exist",destPath.GetData());
		return 0;//失败
	}
}

bool CUpgradeTaskFSM::ExecDeleteCmd(CSimpleStringA &strErrMsg,CInstallStep* ins)
{	
	//只删除同一层目录下的文件和文件夹
	CSimpleStringA destPath ;//目的路径+通配符

	if(ins->dstPathType=="0"){
		CSimpleStringA rootPath;
		if(GetRootTypePath(1,rootPath)){
			destPath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",rootPath.GetData(),ins->dstPath.GetData());//相对路径		
		}else{
			strErrMsg = CSimpleStringA::Format("ExecDeleteCmd destPath GetRootTypePath 1 is fail");
			return false;
		}
	}else if(ins->dstPathType=="1"){

		destPath = ins->dstPath;//绝对路径

	}else if(ins->dstPathType=="2"){
		CSimpleStringA rootPath;
		if(GetRootTypePath(2,rootPath)){
			destPath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",rootPath.GetData(),ins->dstPath.GetData());//当前版本相对路径
		}else{
			strErrMsg = CSimpleStringA::Format("ExecDeleteCmd destPath GetRootTypePath 2 is fail");
			return false;
		}
	
	}else if(ins->dstPathType=="3"){
		CSimpleStringA rootPath;
		if(GetRootTypePath(3,rootPath)){
			destPath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",rootPath.GetData(),ins->dstPath.GetData());//升级版本相对路径
		}else{
			strErrMsg = CSimpleStringA::Format("ExecDeleteCmd destPath GetRootTypePath 3 is fail");
			return false;
		}
	}else{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecDeleteCmd")("ExecDeleteCmd destPathType is invalid %s",ins->dstPathType.GetData());
		strErrMsg = CSimpleStringA::Format("ExecDeleteCmd destPathType is invalid %s",ins->dstPathType.GetData());
		return false;//不支持的路径类型
	}

	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecDeleteCmd")("ExecDeleteCmd destPath is %s",destPath.GetData());

	if(destPath.IndexOf("*")>0){
		CSimpleStringA strFileFilter = _GetFileName(destPath);
		CSimpleStringA strDestDir = destPath.SubString(0, destPath.GetLength()-strFileFilter.GetLength()-1);
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecDeleteCmd")("delete match filter name [%s] in dir [%s]", strFileFilter.GetData(), strDestDir.GetData());
		// 删除所有匹配文件
		bool bRet = true;

		auto arr = fileutil_get_sub_files(strDestDir.GetData());
		if (arr != NULL)
		{
			for (int i = 0; i < arr->nelts; ++i) 
			{
				char *file = ARRAY_IDX(arr, i, char*);			

				if (IsFileMatch(strFileFilter, _GetFileName(file)))
				{
					if(RemoveFileA(file)){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecDeleteCmd")("delete match file succ: [%s]",  file);
					}else{
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecDeleteCmd")("delete match file fail: [%s]",  file);
						strErrMsg = CSimpleStringA::Format("delete match file fail: [%s]",  file);
						bRet = false;
						break;
					}
				}
				else
				{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecDeleteCmd")("ignore not match file: [%s]", file);
				}
				
			}
			toolkit_array_free2(arr);
			if(!bRet){
				return bRet;
			}
		}

		// 删除所有匹配子目录
		auto subdirs = fileutil_get_sub_dirs(strDestDir.GetData());
		if (subdirs != NULL)
		{
			for (int i = 0; i < subdirs->nelts; ++i)
			{
				const char *dir = ARRAY_IDX(subdirs, i, char*);

				if (IsFileMatch(strFileFilter, _GetFileName(dir)))
				{
					if(RemoveDirRecursive(dir)){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecDeleteCmd")("delete match dir succ: [%s]", dir);
					}else{
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecDeleteCmd")("delete match dir fail: [%s]", dir);
						strErrMsg = CSimpleStringA::Format("delete match dir fail: [%s]",  dir);
						bRet = false;
						break;
					}
				}
				else
				{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecDeleteCmd")("ignore not match dir: [%s]", dir);
				}
			}
			toolkit_array_free2(subdirs);
			if(!bRet){
				return bRet;
			}
		}

		return bRet;
	}else{
		//直接删除文件
		bool bRet = true;
		if (ExistsFileA(destPath.GetData()))
		{
			if(RemoveFileA(destPath.GetData())){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecDeleteCmd")("delete match file succ: [%s]",  destPath.GetData());
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecDeleteCmd")("delete match file fail: [%s]",  destPath.GetData());
				strErrMsg = CSimpleStringA::Format("delete match file fail: [%s]",  destPath.GetData());
				bRet = false;
			}
			return bRet;
		}
		else if (ExistsDirA(destPath.GetData()))
		{
			if(RemoveDirRecursiveA(destPath.GetData())){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecDeleteCmd")("delete match dir succ: [%s]",  destPath.GetData());
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecDeleteCmd")("delete match dir fail: [%s]",  destPath.GetData());
				strErrMsg = CSimpleStringA::Format("delete match dir fail: [%s]",  destPath.GetData());
				bRet = false;
			}
			return bRet;
		}
		else
		{
			//指定文件不再则忽略删除此文件
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecDeleteCmd")("delete file [%s] not exists,ignore delete file", destPath.GetData());
			return bRet;
		}
	}
}

bool CUpgradeTaskFSM::ExecCpoyCmd(CSimpleStringA &strErrMsg,CInstallStep* ins)
{
	CSimpleStringA sourcePath ;//路径+通配符

	if(ins->srcPathType=="0"){
		CSimpleStringA rootPath="";
		if(GetRootTypePath(1,rootPath)){
			sourcePath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",rootPath.GetData(),ins->srcPath.GetData());//相对路径
		}else{
			strErrMsg = CSimpleStringA::Format("ExecCpoyCmd sourcePath GetRootTypePath 1 is fail");
			return false;
		}
	}else if(ins->srcPathType=="1"){

		sourcePath = ins->srcPath;//绝对路径

	}else if(ins->srcPathType=="2"){
		CSimpleStringA rootPath="";
		if(GetRootTypePath(2,rootPath)){
			sourcePath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",rootPath.GetData(),ins->srcPath.GetData());//当前版本相对路径
		}else{
			strErrMsg = CSimpleStringA::Format("ExecCpoyCmd sourcePath GetRootTypePath 2 is fail");
			return false;
		}

	}else if(ins->srcPathType=="3"){
		CSimpleStringA rootPath="";
		if(GetRootTypePath(4,rootPath)){
			sourcePath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",rootPath.GetData(),ins->srcPath.GetData());//升级包相对路径
		}else{
			strErrMsg = CSimpleStringA::Format("ExecCpoyCmd sourcePath GetRootTypePath 4 is fail");
			return false;
		}
	}else{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecCpoyCmd")("ExecCpoyCmd srcPathType is invalid %s",ins->srcPathType.GetData());
		strErrMsg = CSimpleStringA::Format("ExecCpoyCmd srcPathType is invalid %s",ins->srcPathType.GetData());
		return false;//不支持的路径类型
	}

	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecCpoyCmd")("ExecCpoyCmd sourcePath is %s",sourcePath.GetData());

	CSimpleStringA destPath ;//目的路径文件夹

	if(ins->dstPathType=="0"){
		CSimpleStringA rootPath="";
		if(GetRootTypePath(1,rootPath)){
			destPath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",rootPath.GetData(),ins->dstPath.GetData());//相对路径
		}else{
			strErrMsg = CSimpleStringA::Format("ExecCpoyCmd destPath GetRootTypePath 1 is fail");
			return false;
		}
	}else if(ins->dstPathType=="1"){

		destPath = ins->dstPath;//绝对路径

	}else if(ins->dstPathType=="2"){
		CSimpleStringA rootPath="";
		if(GetRootTypePath(2,rootPath)){
			destPath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",rootPath.GetData(),ins->dstPath.GetData());//当前版本相对路径
		}else{
			strErrMsg = CSimpleStringA::Format("ExecCpoyCmd destPath GetRootTypePath 2 is fail");
			return false;
		}

	}else if(ins->dstPathType=="3"){
		CSimpleStringA rootPath="";
		if(GetRootTypePath(3,rootPath)){
			destPath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",rootPath.GetData(),ins->dstPath.GetData());//升级版本相对路径
		}else{
			strErrMsg = CSimpleStringA::Format("ExecCpoyCmd destPath GetRootTypePath 3 is fail");
			return false;
		}
	//}else if(ins->dstPathType=="4"){
	//	CSimpleStringA rootPath="";
	//	if(GetRootTypePath(4,rootPath)){
	//		destPath = CSimpleStringA::Format("%s\\%s",rootPath.GetData(),ins->dstPath.GetData());//升级包相对路径
	//	}else{
	//		strErrMsg = CSimpleStringA::Format("ExecCpoyCmd destPath GetRootTypePath 4 is fail");
	//		return false;
	//	}
	}else{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecCpoyCmd")("ExecCpoyCmd dstPathType is invalid %s",ins->dstPathType.GetData());
		strErrMsg = CSimpleStringA::Format("ExecCpoyCmd dstPathType is invalid %s",ins->dstPathType.GetData());
		return false;//不支持的路径类型
	}

	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecCpoyCmd")("ExecCpoyCmd destPath is %s",destPath.GetData());

	if(sourcePath.IndexOf("*")>0){
		//循环匹配拷贝
		//找到要扫描的文件夹
		CSimpleStringA strFileDir = GetFileDirectory(sourcePath.GetData());
		//过滤通配条件
		CSimpleStringA strFileFilter = _GetFileName(sourcePath.GetData());
		list<CSimpleStringA> fileList;
		//获取所有根文件夹下的文件相对路径：如mod\test.dll
		RecursiveGetSubFiles(strFileDir.GetData(), strFileDir.GetData(), fileList);
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecCpoyCmd")("find fileList =%d",fileList.size());
		if(fileList.size()==0){
			//判断mod文件夹未空则报错
			if(sourcePath.IndexOf("mod")!=-1){
				LogWarn(Severity_Low, Error_Exception, WARN_TASK_COPY_FILE_ZERO,CSimpleStringA::Format("ExecCpoyCmd sourcePath is [%s] file is 0",sourcePath.GetData()));
			}
		}
		for(auto it = fileList.begin(); it != fileList.end(); it++)
		{
			if (IsFileMatch(strFileFilter, _GetFileName((const char*)(*it))))
			{
				CSimpleStringA strSrcName = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s", GetFileDirectory(sourcePath.GetData()).GetData(), (const char*)(*it));//源文件路径
				CSimpleStringA strDestName = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s", destPath.GetData(),(const char*)(*it));//目标文件路径
				//匹配成功，开始拷贝文件
				CSimpleStringA errMsg = "";
				ErrorCodeEnum  rc = CopyFileOperate(strSrcName.GetData(),strDestName.GetData(),3,errMsg);
				//DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecCpoyCmd")("copy file [%s] to [%s]  %s", strSrcName.GetData(),strDestName.GetData(), rc == Error_Succeed ? "succeed" : "fail");

				if (rc != Error_Succeed)
				{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecCpoyCmd")("copy file [%s] fail: %s",strSrcName.GetData(),errMsg.GetData());
					strErrMsg = CSimpleStringA::Format("copy file [%s] fail: %s",strSrcName.GetData(),errMsg.GetData());
					return false;//报错
				}
			}
		}
		
	}else{
		//直接拷贝文件：考虑有些文件因智能对比不一定下发，故如果文件不存在，则默认忽略此策略
		CSimpleStringA errMsg = "";
		CSimpleStringA strDestName = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s", destPath.GetData(), _GetFileName(sourcePath.GetData()));
		if(ExistsFileA(sourcePath.GetData())){
			ErrorCodeEnum rc = CopyFileOperate(sourcePath.GetData(),strDestName.GetData(),3,errMsg);
			if (rc != Error_Succeed)
			{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecCpoyCmd")("copy file [%s] fail:%s",sourcePath.GetData(),errMsg.GetData());
				strErrMsg = CSimpleStringA::Format("copy file [%s] fail:%s",sourcePath.GetData(),errMsg.GetData());
				return false;//报错
			}
		}else{
			if(ins->srcPathType=="3"){
				//升级包因智能升级不一定有指定的文件存在
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecCpoyCmd")("拷贝指定的文件[%s]不存在,因智能升级对比过滤,故忽略此文件拷贝",sourcePath.GetData());
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ExecCpoyCmd")("copy file [%s] fail:file to copy not exist",sourcePath.GetData());
				strErrMsg = CSimpleStringA::Format("copy file [%s] fail:file to copy not exist",sourcePath.GetData());
				return false;//报错
			}
			
		}	
	}
	return true;
}

bool CUpgradeTaskFSM::GetRootTypePath(int rootType,CSimpleStringA &Path)
{
	CSimpleStringA tempPath;
	if(rootType == 1){

		ErrorCodeEnum Error =m_pEntity->GetFunction()->GetPath("Root",tempPath);//例如：C:\Run  /opt/Run
		if(Error_Succeed == Error){
			if(!tempPath.IsNullOrEmpty()){
				string runPathStr = tempPath.GetData();
				int pos = runPathStr.find_last_of(SPLIT_SLASH);
				Path = runPathStr.substr(0,pos).c_str();
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetRootTypePath")("get Root path is null");
				return false;
			}
		}else{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetRootTypePath")("get Root path is error");
			return false;
		}

	}else if(rootType == 2){

		ErrorCodeEnum Error =m_pEntity->GetFunction()->GetPath("Base",tempPath);//例如：C:\Run\version\4.8.1.1  /opt/Run/version/4.8.1.1
		if(Error_Succeed == Error){
			if(!tempPath.IsNullOrEmpty()){
				Path = tempPath;
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetRootTypePath")("get currVer path is null");
				return false;
			}
		}else{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetRootTypePath")("get currVer path is error");
			return false;
		}

	}else if(rootType == 3){

		ErrorCodeEnum Error =m_pEntity->GetFunction()->GetPath("RootVer",tempPath);//例如：C:\Run\version\4.9.1.1  /opt/Run/version/4.9.1.1
		if(Error_Succeed == Error){
			if(!tempPath.IsNullOrEmpty()){
				Path = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s", tempPath.GetData(), m_currentTask.pack_version.GetData());
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetRootTypePath")("get currVer path is null");
				return false;
			}
			
		}else{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetRootTypePath")("get upgradeVer path is error");
			return false;
		}
	}else if(rootType == 4){

		ErrorCodeEnum Error =m_pEntity->GetFunction()->GetPath("Downloads",tempPath);//例如：C:\rvc\Downloads\4.8.1.1  /opt/rvc/Downloads/4.8.1.1
		if(Error_Succeed == Error){
			if(!tempPath.IsNullOrEmpty()){
				CSimpleStringA strUnzipDir;
				strUnzipDir = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s", tempPath.GetData(), m_currentTask.pack_name.GetData());
				//解压去除了.zip后缀
				if (strUnzipDir.IsEndWith(".zip")){
					Path = strUnzipDir.SubString(0, strUnzipDir.GetLength()-4);
				}else{
					Path = strUnzipDir;
				}
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetRootTypePath")("get upgradePack path is null");
				return false;
			}
		}else{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetRootTypePath")("get upgradePack path is error");
			return false;
		}
	}
	return true;
}

ErrorCodeEnum CUpgradeTaskFSM::CopyFileOperate(const char* srcPath, const char* destPath, int nCopyMode, CSimpleStringA &strErrMsg)
{
	//源文件是否存在
	if (!ExistsFileA(srcPath))
	{
		strErrMsg = CSimpleStringA::Format("CopyFileOperate file [%s] to copy not exist", srcPath);
		return Error_NotExist;
	}
	//目标文件夹是否存在
	CSimpleStringA strDestDir = GetFileDirectory(destPath);
	if (!ExistsDirA(strDestDir.GetData())){
		if(!CreateDirA(strDestDir.GetData(), TRUE)){
			strErrMsg = CSimpleStringA::Format("CopyFileOperate create strDestDir[%s] fail", strDestDir.GetData());
			return Error_Exception;
		}
	}
	//目标文件是否存在
	BOOL bDestFileExists = ExistsFileA(destPath);
	if (bDestFileExists){
		RemoveFileReadOnlyAttributeA(destPath);
	}
	BOOL bRet = TRUE;

	switch (nCopyMode)
	{
	case 1:
		{
		if (bDestFileExists) {
#ifdef RVC_OS_WIN
			bRet = CopyFileA(srcPath, destPath, FALSE);
#else
			if (fileutil_copy_file(destPath, srcPath) == 0) {
				bRet = TRUE;
			}
			else {
				bRet = FALSE;
			}
#endif
		}
		else {
			LOG_TRACE("ignore file [%s] copy for dest file not exists", srcPath);
		}
		}
		break;
	case 2:
		{
			if (!bDestFileExists)
#ifdef RVC_OS_WIN
				bRet = CopyFileA(srcPath, destPath, TRUE);
#else
				if (fileutil_copy_file(destPath, srcPath) == 0) {
					bRet = TRUE;
				}
				else {
					bRet = FALSE;
				}
#endif
			else
				LOG_TRACE("ignore file [%s] copy for dest file exists", srcPath);
		}
		break;
	case 3:
#ifdef RVC_OS_WIN
		bRet = CopyFileA(srcPath, destPath, FALSE);
#else
		if (fileutil_copy_file(destPath, srcPath) == 0) {
			bRet = TRUE;
		}
		else {
			bRet = FALSE;
		}
#endif
		break;
	case 4:
		{
			// 不发生拷贝，只进行判断
			if(bDestFileExists)
				LOG_TRACE("file [%s] exist", srcPath);
			else
				LOG_TRACE("file [%s] not exist", srcPath);
		}
		break;
	}

	if (bRet){
		RemoveFileReadOnlyAttributeA(destPath);
	}else{
#ifdef RVC_OS_WIN
		strErrMsg = CSimpleStringA::Format("CopyFileOperate copy file fail:%d", GetLastError());
#else
		strErrMsg = CSimpleStringA::Format("CopyFileOperate copy file fail:%d", errno);
#endif
	}
	ErrorCodeEnum rc = bRet ? Error_Succeed : Error_Unexpect;
	return rc;
}

ErrorCodeEnum CUpgradeTaskFSM::SetRunSucceed(const char* pPackFile)
{
	// 拷贝升级包到Upgraded目录
	CSimpleStringA strDownloadPath, strUpgradedPath;
	ErrorCodeEnum rc = m_pEntity->GetFunction()->GetPath("Downloads", strDownloadPath);
	if(rc!=Error_Succeed){
		return rc;
	}
	rc = m_pEntity->GetFunction()->GetPath("Upgraded", strUpgradedPath);
	if(rc!=Error_Succeed){
		return rc;
	}
	CSimpleStringA strSourcePath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s", (const char*)strDownloadPath, pPackFile);
	CSimpleStringA strDestPath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s", (const char*)strUpgradedPath, pPackFile);
#ifdef RVC_OS_WIN
	CopyFileA(strSourcePath.GetData(), strDestPath.GetData(), FALSE);
#else
	fileutil_copy_file(strDestPath.GetData(), strSourcePath.GetData());
#endif
	return Error_Succeed;
}

ErrorCodeEnum CUpgradeTaskFSM::UpgradeToNewVersion()
{
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UpgradeToNewVersion")("begin UpgradeToNewVersion");
	//获取新版本号
	if(m_currentTask.NewVersion.IsNullOrEmpty()){
		if(m_currentTask.pack_version.IsNullOrEmpty()){
			return Error_Succeed;
		}else{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UpgradeToNewVersion")("NewVersion is null, pack_version=[%s] is not null,UpgradeToNewVersion fail, taskID=[%s]",m_currentTask.pack_version.GetData(), m_currentTask.upgradeTaskId.GetData());
			LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_ACTIVE_FAIL, CSimpleStringA::Format("UpgradeToNewVersion fail, NewVersion is null, pack_version [%s] is not null,fail",m_currentTask.pack_version.GetData()).GetData());
			return Error_Unexpect;//这种情况有问题，需要清除此任务
		}
	}else{
		CSimpleStringA rootVerPath;
		ErrorCodeEnum rc = m_pEntity->GetFunction()->GetPath("RootVer",rootVerPath);//获取version根路径
		if(rc!=Error_Succeed){
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UpgradeToNewVersion")("UpgradeToNewVersion fail , get RootVer path is fail");
			LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_ACTIVE_FAIL,"UpgradeToNewVersion: get RootVer path is fail");
			return Error_Bug;
		}
		CSimpleStringA strNewVerPath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s", rootVerPath.GetData(), m_currentTask.NewVersion.GetData());
		if(!ExistsDirA(strNewVerPath.GetData())){
			LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_ACTIVE_FAIL,CSimpleStringA::Format("UpgradeToNewVersion fail, strNewVerPath =%s is not exist,fail",strNewVerPath.GetData()).GetData());
			return Error_Unexpect;//这种情况有问题，需要清除此任务
		}
		//修改运行时文件

		//修改active配置
		CSimpleStringA strActiveFile = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "active.txt", rootVerPath.GetData());
		if(!ExistsFileA(strActiveFile.GetData())){
			//LogError(Severity_Low, Error_Unexpect, 0, "open active.txt fail,active file is not exist");
			LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_ACTIVE_FAIL,"UpgradeToNewVersion fail, active file is not exist");
			return Error_Unexpect;
		}
		//先做active文件备份，后面写入失败再copy回去
#ifdef RVC_OS_WIN
		bool backupSucc = true;
		CSimpleStringA strBackupActiveFile = CSimpleStringA::Format("%s\\back_active.txt", rootVerPath.GetData());
		if(!CopyFileA(strActiveFile.GetData(),strBackupActiveFile.GetData(),FALSE)){
			LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_ACTIVE_FAIL,CSimpleStringA::Format("UpgradeToNewVersion fail, back up active.txt fail, err=%d",(int)GetLastError()).GetData());
			backupSucc = false;
		}
		FILE* fp = fopen(strActiveFile.GetData(),"wb+");
		if(fp==NULL){
			//LogError(Severity_Low, Error_Unexpect, 0, "open active.txt fail");
			LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_ACTIVE_FAIL,CSimpleStringA::Format("UpgradeToNewVersion fail, open write active.txt fail, err=%d",(int)GetLastError()).GetData());
			return Error_Unexpect;
		}
		int ret = fwrite(m_currentTask.NewVersion.GetData(),m_currentTask.NewVersion.GetLength(),1,fp);
		if(ret!=1){
			//LogError(Severity_Low, Error_Unexpect, 0, "write active.txt fail");
			LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_ACTIVE_FAIL,CSimpleStringA::Format("UpgradeToNewVersion fail, write active.txt fail, err=%d",(int)GetLastError()).GetData());
			fclose(fp);
			if(backupSucc){
				if(CopyFileA(strBackupActiveFile.GetData(),strActiveFile.GetData(),FALSE)){
					RemoveFileA(strBackupActiveFile.GetData());
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UpgradeToNewVersion")("back_active.txt copy to active.txt is succ");
				}else{
					LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_ACTIVE_FAIL,CSimpleStringA::Format("UpgradeToNewVersion fail, back_active.txt copy to active.txt is fail, err=%d",(int)GetLastError()).GetData());
				}
			}
			return Error_Unexpect;
		}else{
			fflush(fp);
			fclose(fp);
			if (ExistsFileA(strBackupActiveFile.GetData())) {
				RemoveFileA(strBackupActiveFile.GetData());
			}
		}

		//重新读active文件,看文件内容是什么
		fp = fopen(strActiveFile.GetData(),"rb");
		if(fp==NULL){
			//LogError(Severity_Low, Error_Unexpect, 0, "open active.txt fail");
			LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_ACTIVE_FAIL,CSimpleStringA::Format("UpgradeToNewVersion fail, open read active.txt fail, err=%d",(int)GetLastError()).GetData());
			return Error_Unexpect;
		}
		char cVer[16] = {0};
		int re = fread(cVer,m_currentTask.NewVersion.GetLength(),1,fp);
		if(re!=1){
			//LogError(Severity_Low, Error_Unexpect, 0, "Read active.txt fail");
			LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_ACTIVE_FAIL,CSimpleStringA::Format("UpgradeToNewVersion fail, read active.txt fail, err=%d",(int)GetLastError()).GetData());
		}else{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UpgradeToNewVersion")("read active.txt, version[%s]", cVer);
		}
		fclose(fp);
		return Error_Succeed;
#else
		bool backupSucc = true;
		CSimpleStringA strBackupActiveFile = CSimpleStringA::Format("%s\\back_active.txt", rootVerPath.GetData());
		if (fileutil_copy_file( strBackupActiveFile.GetData(),strActiveFile.GetData())!=0) {
			LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_ACTIVE_FAIL, CSimpleStringA::Format("UpgradeToNewVersion fail, back up active.txt fail, err=%d", errno).GetData());
			backupSucc = false;
		}
		FILE* fp = fopen(strActiveFile.GetData(),"wb+");
		if(fp==NULL){
			//LogError(Severity_Low, Error_Unexpect, 0, "open active.txt fail");
			LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_ACTIVE_FAIL, CSimpleStringA::Format("UpgradeToNewVersion fail, open write active.txt fail, err=%d", errno).GetData());
			return Error_Unexpect;
		}
		int ret = fwrite(m_currentTask.NewVersion.GetData(),m_currentTask.NewVersion.GetLength(),1,fp);
		if(ret!=1){
			//LogError(Severity_Low, Error_Unexpect, 0, "write active.txt fail");
			LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_ACTIVE_FAIL, CSimpleStringA::Format("UpgradeToNewVersion fail, write active.txt fail, err=%d", errno).GetData());
			fclose(fp);
			if (backupSucc) {
				if (fileutil_copy_file(strActiveFile.GetData(), strBackupActiveFile.GetData())==0) {
					RemoveFileA(strBackupActiveFile.GetData());
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UpgradeToNewVersion")("back_active.txt copy to active.txt is succ");
				}else{
					LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_ACTIVE_FAIL, CSimpleStringA::Format("UpgradeToNewVersion fail, back_active.txt copy to active.txt is fail, err=%d", errno).GetData());
				}
			}
			return Error_Unexpect;
		}else{
			fflush(fp);
			fclose(fp);
			if (ExistsFileA(strBackupActiveFile.GetData())) {
				RemoveFileA(strBackupActiveFile.GetData());
			}
		}

		//重新读active文件,看文件内容是什么
		fp = fopen(strActiveFile.GetData(),"rb");
		if(fp==NULL){
			//LogError(Severity_Low, Error_Unexpect, 0, "open active.txt fail");
			LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_ACTIVE_FAIL,CSimpleStringA::Format("UpgradeToNewVersion fail, open read active.txt fail, err=%d", errno).GetData());
			return Error_Unexpect;
		}
		char cVer[16] = {0};
		int re = fread(cVer,m_currentTask.NewVersion.GetLength(),1,fp);
		if(re!=1){
			//LogError(Severity_Low, Error_Unexpect, 0, "Read active.txt fail");
			LogWarn(Severity_Middle, Error_Exception, ERR_TASK_UPDATE_ACTIVE_FAIL,CSimpleStringA::Format("UpgradeToNewVersion fail, read active.txt fail, err=%d", errno).GetData());
		}else{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UpgradeToNewVersion")("read active.txt, version[%s]", cVer);
		}
		fclose(fp);
		return Error_Succeed;
#endif
	}



	
}

ErrorCodeEnum CUpgradeTaskFSM::RollBackToHistoryVersion(CVersion historyVersion)
{
	// 判断目标版本是否小于当前版本
	CVersion v=m_currentVersion;//当前版本
	CVersion curVersion(v.GetMajor(), v.GetMinor(), v.GetRevision(), v.GetBuild());
	if (curVersion <= historyVersion)
	{
		LogWarn(Severity_Middle, Error_Exception, ERR_TASK_ROLL_BACK_ACTIVE_FAIL, CSimpleStringA::Format("history version [%s] >= current version [%s]", historyVersion.ToString().GetData(), curVersion.ToString().GetData()).GetData());
		return Error_Param;
	}

	// 检查对应文件夹是否存在
	CSimpleStringA strHisVersion = historyVersion.ToString();
	CSimpleStringA rootVerPath;
	ErrorCodeEnum rc = m_pEntity->GetFunction()->GetPath("RootVer",rootVerPath);//获取version根路径
	if(rc!=Error_Succeed){
		LogWarn(Severity_Middle, Error_Exception, ERR_TASK_ROLL_BACK_ACTIVE_FAIL, "RollBackToHistoryVersion fail , get RootVer path is fail");
		return Error_Bug;
	}

	CSimpleStringA strHisVerPath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s", rootVerPath.GetData(), strHisVersion.GetData());
	if (!ExistsDirA(strHisVerPath.GetData()))
	{
		LogWarn(Severity_Middle, Error_Exception, ERR_TASK_ROLL_BACK_ACTIVE_FAIL, CSimpleStringA::Format("RollBackToHistoryVersion fail, history version dir [%s] not exists", strHisVerPath.GetData()).GetData());
		return Error_NotExist;
	}
	//删除当时的运行缓存值

	// 修改active.txt文件，可能存在失败
	CSimpleStringA strActiveFile = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "active.txt", rootVerPath.GetData());
	if(!ExistsFileA(strActiveFile.GetData())){
		LogWarn(Severity_Middle, Error_Exception, ERR_TASK_ROLL_BACK_ACTIVE_FAIL, "RollBackToHistoryVersion fail, active file is not exist");
		return Error_Unexpect;
	}
	//先做active文件备份，后面写入失败再copy回去
#ifdef RVC_OS_WIN
	bool backupSucc = true;
	CSimpleStringA strBackupActiveFile = CSimpleStringA::Format("%s\\Rollback_active.txt", rootVerPath.GetData());
	if(!CopyFileA(strActiveFile.GetData(),strBackupActiveFile.GetData(),FALSE)){
		LogWarn(Severity_Middle, Error_Exception, ERR_TASK_ROLL_BACK_ACTIVE_FAIL,CSimpleStringA::Format("RRollBackToHistoryVersion fail, back up active.txt fail, err=%d",(int)GetLastError()).GetData());
		backupSucc = false;
	}

	FILE* fp = fopen(strActiveFile.GetData(),"wb+");
	if(fp==NULL){
		LogWarn(Severity_Middle, Error_Exception, ERR_TASK_ROLL_BACK_ACTIVE_FAIL, CSimpleStringA::Format("RRollBackToHistoryVersion fail, open write active.txt fail,err=%d", (int)GetLastError()).GetData());
		return Error_Unexpect;
	}
	int ret = fwrite(strHisVersion.GetData(),strHisVersion.GetLength(),1,fp);
	if(ret!=1){
		LogWarn(Severity_Middle, Error_Exception, ERR_TASK_ROLL_BACK_ACTIVE_FAIL, CSimpleStringA::Format("RRollBackToHistoryVersion fail, write active.txt fail,err=%d", (int)GetLastError()).GetData());
		fclose(fp);
		if(backupSucc){
			if(CopyFileA(strBackupActiveFile.GetData(),strActiveFile.GetData(),FALSE)){
				RemoveFileA(strBackupActiveFile.GetData());
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RollBackToHistoryVersion")("Rollback_active.txt copy to active.txt is succ");
			}else{
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_ROLL_BACK_ACTIVE_FAIL,CSimpleStringA::Format("RRollBackToHistoryVersion fail, Rollback_active.txt copy to active.txt is fail, err=%d",(int)GetLastError()).GetData());
			}
		}
		return Error_Unexpect;
	}else{
		fflush(fp);
		fclose(fp);
		if (ExistsFileA(strBackupActiveFile.GetData())) {
			RemoveFileA(strBackupActiveFile.GetData());
		}
	}

	//重新读active文件,看文件内容是什么
	fp = fopen(strActiveFile.GetData(),"rb");
	if(fp==NULL){
		LogWarn(Severity_Middle, Error_Exception, ERR_TASK_ROLL_BACK_ACTIVE_FAIL, CSimpleStringA::Format("RRollBackToHistoryVersion fail, open read active.txt fail,err=%d", (int)GetLastError()).GetData());
		return Error_Unexpect;
	}
	char cVer[16] = {0};
	int re = fread(cVer,strHisVersion.GetLength(),1,fp);
	if(re!=1){
		LogWarn(Severity_Middle, Error_Exception, ERR_TASK_ROLL_BACK_ACTIVE_FAIL, CSimpleStringA::Format("RRollBackToHistoryVersion fail, Read active.txt fail,err=%d", (int)GetLastError()).GetData());
	}else{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RollBackToHistoryVersion")("read active.txt, version[%s]", cVer);
	}
	fclose(fp);

	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RollBackToHistoryVersion")("set rollback to history version [%s] succeed", (const char*)strHisVersion);
	return Error_Succeed;
#else
	bool backupSucc = true;
	CSimpleStringA strBackupActiveFile = CSimpleStringA::Format("%s\\Rollback_active.txt", rootVerPath.GetData());
	if (fileutil_copy_file(strBackupActiveFile.GetData(), strActiveFile.GetData())!=0) {
		LogWarn(Severity_Middle, Error_Exception, ERR_TASK_ROLL_BACK_ACTIVE_FAIL, CSimpleStringA::Format("RRollBackToHistoryVersion fail, back up active.txt fail, err=%d", errno).GetData());
		backupSucc = false;
	}

	FILE* fp = fopen(strActiveFile.GetData(),"wb+");
	if(fp==NULL){
		LogWarn(Severity_Middle, Error_Exception, ERR_TASK_ROLL_BACK_ACTIVE_FAIL, CSimpleStringA::Format("RRollBackToHistoryVersion fail, open write active.txt fail,err=%d", errno).GetData());
		return Error_Unexpect;
	}
	int ret = fwrite(strHisVersion.GetData(),strHisVersion.GetLength(),1,fp);
	if(ret!=1){
		LogWarn(Severity_Middle, Error_Exception, ERR_TASK_ROLL_BACK_ACTIVE_FAIL, CSimpleStringA::Format("RRollBackToHistoryVersion fail, write active.txt fail,err=%d", errno).GetData());
		fclose(fp);
		if (backupSucc) {
			if (fileutil_copy_file(strActiveFile.GetData(), strBackupActiveFile.GetData())==0) {
				RemoveFileA(strBackupActiveFile.GetData());
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RollBackToHistoryVersion")("Rollback_active.txt copy to active.txt is succ");
			}else{
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_ROLL_BACK_ACTIVE_FAIL, CSimpleStringA::Format("RRollBackToHistoryVersion fail, Rollback_active.txt copy to active.txt is fail, err=%d", errno).GetData());
			}
		}
		return Error_Unexpect;
	}else{
		fflush(fp);
		fclose(fp);
		if (ExistsFileA(strBackupActiveFile.GetData())) {
			RemoveFileA(strBackupActiveFile.GetData());
		}
	}

	//重新读active文件,看文件内容是什么
	fp = fopen(strActiveFile.GetData(),"rb");
	if(fp==NULL){
		LogWarn(Severity_Middle, Error_Exception, ERR_TASK_ROLL_BACK_ACTIVE_FAIL, CSimpleStringA::Format("RRollBackToHistoryVersion fail, open read active.txt fail,err=%d", errno).GetData());
		return Error_Unexpect;
	}
	char cVer[16] = {0};
	int re = fread(cVer,strHisVersion.GetLength(),1,fp);
	if(re!=1){
		LogWarn(Severity_Middle, Error_Exception, ERR_TASK_ROLL_BACK_ACTIVE_FAIL, CSimpleStringA::Format("RRollBackToHistoryVersion fail, Read active.txt fail,err=%d", errno).GetData());
	}else{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RollBackToHistoryVersion")("read active.txt, version[%s]", cVer);
	}
	fclose(fp);

	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RollBackToHistoryVersion")("set rollback to history version [%s] succeed", (const char*)strHisVersion);
	return Error_Succeed;
#endif	
}

void CUpgradeTaskFSM::RecursiveGetSubFiles(const char *pszDir, const char *pszTrimStart,  list<CSimpleStringA>& retList)
{
	if (!ExistsDirA(pszDir))
		return;

	auto arr = fileutil_get_sub_files(pszDir);
	if (arr != NULL)
	{
		for (int i = 0; i < arr->nelts; ++i) 
		{
			char *file = ARRAY_IDX(arr, i, char*);							
#ifdef RVC_OS_WIN
			//不区分大小写
			if (pszTrimStart != NULL && strnicmp(file, pszTrimStart, strlen(pszTrimStart))==0) {
#else
			//区分大小写
			if (pszTrimStart != NULL && strncmp(file, pszTrimStart, strlen(pszTrimStart)) == 0) {
#endif
				file += strlen(pszTrimStart);

				if (*file == SPLIT_SLASH)
					file++;
			}
			retList.push_back(file);
		}
		toolkit_array_free2(arr);
	}

	arr = fileutil_get_sub_dirs(pszDir);
	if (arr != NULL)
	{
		for (int i = 0; i < arr->nelts; ++i) 
		{
			char *dir = ARRAY_IDX(arr, i, char*);							
			RecursiveGetSubFiles(dir, pszTrimStart, retList);
		}
		toolkit_array_free2(arr);
	}
}

bool CUpgradeTaskFSM::IsFileMatch(const char *pszFilter, const char *pszFileName)
{
	const char *p1 = pszFilter;
	const char *p2 = pszFileName;

	if (p1 == NULL)
		return true;

	if (p2 == NULL)
		return false;

	if (*p1 ==NULL && *p2 ==NULL)
		return true;
	else if (*p1 == NULL)
		return false;
	else if (*p2 == NULL)
	{
		// 查找*p1是否全是*
		while(*p1 == '*') 
			p1++;

		if (*p1 == NULL)
			return true;
		else
			return false;
	}

	if (*p1 != '*')
	{
		if (tolower(*p1) != tolower(*p2))
			return false;
		else
			return IsFileMatch(p1+1, p2+1);
	}
	else
	{
		while(*++p1 == '*');

		if (*p1 == NULL)
			return true;

		while (*p2)
		{
			while(tolower(*p1) != tolower(*p2) && *++p2);

			if (*p2  == NULL)
				return false;

			if(IsFileMatch(p1+1, p2+1))
				return true;

			p2++;
		}

		return false;
	}
}

bool CUpgradeTaskFSM::RecursiveCopyDir(const char *pszSourceDir, const char *pszDestDir,CSimpleStringA &strErrInfo)
{
	array_header_t *arr;
#ifdef RVC_OS_WIN
	if (!ExistsDirA(pszSourceDir))
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RecursiveCopyDir")("source dir [%s] not exists: %d", pszSourceDir,GetLastError());
		strErrInfo = CSimpleStringA::Format("source dir [%s] not exists: %d", pszSourceDir, GetLastError());
		return false;
	}

	if (!ExistsDirA(pszDestDir))
	{
		if (!CreateDirRecursiveA(pszDestDir))
		{
			strErrInfo = CSimpleStringA::Format("create dir [%s] fail: %d", pszDestDir, GetLastError());
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RecursiveCopyDir")("create dir fail: %s",strErrInfo.GetData());
			return false;
		}

		//DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RecursiveCopyDir")("create dir [%s] succ", pszDestDir);
	}
#else
	if (!ExistsDirA(pszSourceDir))
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RecursiveCopyDir")("source dir [%s] not exists: %d", pszSourceDir, errno);
		strErrInfo = CSimpleStringA::Format("source dir [%s] not exists: %d", pszSourceDir, errno);
		return false;
	}

	if (!ExistsDirA(pszDestDir))
	{
		if (!CreateDirRecursiveA(pszDestDir))
		{
			strErrInfo = CSimpleStringA::Format("create dir [%s] fail: %d", pszDestDir, errno);
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RecursiveCopyDir")("create dir fail: %s",strErrInfo.GetData());
			return false;
		}

		//DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RecursiveCopyDir")("create dir [%s] succ", pszDestDir);
	}
#endif
	arr = fileutil_get_sub_files_a(pszSourceDir);
	if (arr)
	{
		int i;
		for (i = 0; i < arr->nelts; ++i)
		{
			char szDestFile[256] = { 0 };
			char *file = ARRAY_IDX(arr, i, char*);
			strcpy(szDestFile, pszDestDir);
			if (szDestFile[strlen(szDestFile) - 1] != SPLIT_SLASH)
				strcat(szDestFile, SPLIT_SLASH_STR);
			strcat(szDestFile, strrchr(file, SPLIT_SLASH) + 1);

#ifdef RVC_OS_WIN
			if (!CopyFileA(file, szDestFile, FALSE))
			{
				strErrInfo = CSimpleStringA::Format("copy file [%s] fail: %d", file, GetLastError());
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RecursiveCopyDir")("copy file fail:%s",strErrInfo.GetData());
				toolkit_array_free2(arr);
				return false;
			}
#else
			if (fileutil_copy_file(szDestFile, file)!=0)
			{
				strErrInfo = CSimpleStringA::Format("copy file [%s] fail: %d", file, errno);
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RecursiveCopyDir")("copy file fail:%s",strErrInfo.GetData());
				toolkit_array_free2(arr);
				return false;
			}
#endif						
		}
		toolkit_array_free2(arr);
	}

	arr = fileutil_get_sub_dirs_a(pszSourceDir);
	if (arr)
	{
		int i;
		for (i = 0; i < arr->nelts; ++i)
		{
			char szDestSubDir[256] = { 0 };
			char *dir = ARRAY_IDX(arr, i, char*);
			strcpy(szDestSubDir, pszDestDir);
			if (szDestSubDir[strlen(szDestSubDir) - 1] != SPLIT_SLASH)
				strcat(szDestSubDir, SPLIT_SLASH_STR);
			strcat(szDestSubDir, strrchr(dir, SPLIT_SLASH) + 1);

			if (!RecursiveCopyDir(dir, szDestSubDir,strErrInfo))
			{
#ifdef RVC_OS_WIN
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RecursiveCopyDir")("copy dir [%s] fail: %d", dir, GetLastError());
				if(strErrInfo.IsNullOrEmpty()){
					strErrInfo = CSimpleStringA::Format("copy dir [%s] fail: %d", dir, GetLastError());
				}
				toolkit_array_free2(arr);
				return false;
#else
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RecursiveCopyDir")("copy dir [%s] fail: %d", dir, errno);
				if (strErrInfo.IsNullOrEmpty()) {
					strErrInfo = CSimpleStringA::Format("copy dir [%s] fail: %d", dir, errno);
				}
				toolkit_array_free2(arr);
				return false;
#endif				
			}

			//DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("RecursiveCopyDir")("copy dir [%s] succ", dir);
		}
		toolkit_array_free2(arr);
	}

	return true;
}

CSimpleStringA CUpgradeTaskFSM::GetFileDirectory(const char *pszFullPath)
{
	int i=strlen(pszFullPath)-1;
	for( ; i>0 && pszFullPath[i]!= SPLIT_SLASH; i--)NULL;
	return CSimpleStringA(pszFullPath, i);
}

bool CUpgradeTaskFSM::IsWow64Process()
{
#ifdef RVC_OS_WIN
	typedef BOOL(WINAPI *LPFN_ISWOW64PROCESS)(HANDLE, PBOOL);
	LPFN_ISWOW64PROCESS fnIsWow64Process = (LPFN_ISWOW64PROCESS)GetProcAddress(GetModuleHandle("kernel32"), "IsWow64Process");

	BOOL bIsWow64 = FALSE;
	if (NULL != fnIsWow64Process)
	{
		if (!fnIsWow64Process(GetCurrentProcess(), &bIsWow64))
		{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("IsWow64Process")("call IsWow64Process error: %d", GetLastError());
			return false;
		}

		return bIsWow64 == TRUE;
	}
	else
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("IsWow64Process")("get IsWow64Process error: %d", GetLastError());
		return false;
	}
#endif
	return true;
}

int CUpgradeTaskFSM::system_on(string cmdFilePath, bool isWait,CSimpleStringA &errMsg)
{
#ifdef RVC_OS_WIN
	string cmdLine = "cmd /c ";
	cmdLine.append(cmdFilePath.c_str());
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("system_on")("exec bat %s",cmdLine.c_str());
	return waitSystem("cmd.exe", cmdLine.c_str(), true, errMsg);
#else
	//linux直接用system函数即可
	return system(cmdFilePath.c_str());
#endif
}
//返回值是0则正常执行，其他都是非正常未知状态
int CUpgradeTaskFSM::waitSystem(string cmd, const char * par, bool nShow,CSimpleStringA &errMsg)
{
#ifdef RVC_OS_WIN
	SHELLEXECUTEINFOA ShExecInfo = { 0 };
	ShExecInfo.cbSize = sizeof(SHELLEXECUTEINFO);
	ShExecInfo.fMask = SEE_MASK_NOCLOSEPROCESS;
	ShExecInfo.hwnd = NULL;
	ShExecInfo.lpVerb = NULL;
	ShExecInfo.lpFile = cmd.c_str();  //调用的程序名
	ShExecInfo.lpParameters = par; //调用程序的命令行参数
	ShExecInfo.lpDirectory = NULL;
	ShExecInfo.nShow = nShow ? SW_MINIMIZE: SW_HIDE;  //窗口状态为隐藏
	ShExecInfo.hInstApp = NULL;

	if (!ShellExecuteEx(&ShExecInfo))
	{
		errMsg = CSimpleStringA::Format("shellExecute is fail :%d",GetLastError());
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("waitSystem")("shellExecute is fail :%s",errMsg.GetData());
		return -1;
	}
	//等到该进程结束,如果5分钟没结束，强行杀死进程
	if (WaitForSingleObject(ShExecInfo.hProcess, 5*60*1000) == WAIT_TIMEOUT)
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("waitSystem")("shellExecute is time out");
		errMsg = CSimpleStringA::Format("shellExecute is time out");	
		if (TerminateProcess(ShExecInfo.hProcess, 0))
		{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("waitSystem")("TerminateProcess is succ");

		}else {
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("waitSystem")("TerminateProcess is fail :%d",GetLastError());
		}
		if (CloseHandle(ShExecInfo.hProcess)) 
		{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("waitSystem")("shellExecute CloseHandle is succ");
		}else {
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("waitSystem")("shellExecute CloseHandle is fail");
		}
		return -1;
	}

	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("waitSystem")("shellExecute is succ");
	DWORD exitCode = 0;
	if (!GetExitCodeProcess(ShExecInfo.hProcess, &exitCode))
	{
		errMsg = CSimpleStringA::Format("GetExitCodeProcess is fail:%d",GetLastError());
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("waitSystem")("GetExitCodeProcess is fail:%s",errMsg.GetData());
		return -1;
	}
	if (CloseHandle(ShExecInfo.hProcess)) 
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("waitSystem")("shellExecute CloseHandle is succ");
	}else {
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("waitSystem")("shellExecute CloseHandle is fail");
	}
	if(exitCode!=0){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("waitSystem")("GetExitCodeProcess ret exitCode=%d",(int)exitCode);
		errMsg = CSimpleStringA::Format("GetExitCodeProcess ret exitCode=%d",(int)exitCode);
	}
	return exitCode;
#else
	return 0;
#endif
}

char* CUpgradeTaskFSM::ConvertUtf8ToGBK(const char* strUtf8)
{
	int len = MultiByteToWideChar(CP_UTF8, 0, strUtf8, -1, NULL, 0);
	WCHAR* wszGBK = new WCHAR[len + 1];
	memset(wszGBK, 0, len * 2 + 2);
	MultiByteToWideChar(CP_UTF8, 0, strUtf8, -1, wszGBK, len);

	len = WideCharToMultiByte(CP_ACP, 0, wszGBK, -1, NULL, 0, NULL, NULL);
	char* szGBK = new char[len + 1];
	memset(szGBK, 0, len + 1);
	WideCharToMultiByte(CP_ACP, 0, wszGBK, -1, szGBK, len, NULL, NULL);
	delete[] wszGBK;

	return szGBK;
}

void CUpgradeTaskFSM::ConvertUtf8ToGBK(std::string &str)
{
	char *dst = ConvertUtf8ToGBK(str.c_str());
	str = dst;
	delete[] dst;
}

char* CUpgradeTaskFSM::ConvertGBKToUtf8(const char* gbk, int *n)
{
	int len = MultiByteToWideChar(CP_ACP, 0, gbk, -1, NULL, 0);
	WCHAR* wszGBK = new WCHAR[len + 1];
	memset(wszGBK, 0, len * 2 + 2);
	MultiByteToWideChar(CP_ACP, 0, gbk, -1, wszGBK, len);

	len = WideCharToMultiByte(CP_UTF8, 0, wszGBK, -1, NULL, 0, NULL, NULL);
	char* szUtf8 = new char[len + 1];
	memset(szUtf8, 0, len + 1);
	WideCharToMultiByte(CP_UTF8, 0, wszGBK, -1, szUtf8, len, NULL, NULL);

	delete[] wszGBK;
	*n = len  - 1;
	return szUtf8;
}

void CUpgradeTaskFSM::ConvertGBKToUtf8(std::string &str)
{
	int len = 0;
	char *dst = ConvertGBKToUtf8(str.c_str(), &len);

	str = dst;
	delete[] dst;
}

bool CUpgradeTaskFSM::is_str_utf8(const char* str)
{
	unsigned int nBytes = 0;//UFT8可用1-6个字节编码,ASCII用一个字节  
	unsigned char chr = *str;
	bool bAllAscii = true;

	for (unsigned int i = 0; str[i] != '\0'; ++i) {
		chr = *(str + i);
		//判断是否ASCII编码,如果不是,说明有可能是UTF8,ASCII用7位编码,最高位标记为0,0xxxxxxx 
		if (nBytes == 0 && (chr & 0x80) != 0) {
			bAllAscii = false;
		}

		if (nBytes == 0) {
			//如果不是ASCII码,应该是多字节符,计算字节数  
			if (chr >= 0x80) {

				if (chr >= 0xFC && chr <= 0xFD) {
					nBytes = 6;
				}
				else if (chr >= 0xF8) {
					nBytes = 5;
				}
				else if (chr >= 0xF0) {
					nBytes = 4;
				}
				else if (chr >= 0xE0) {
					nBytes = 3;
				}
				else if (chr >= 0xC0) {
					nBytes = 2;
				}
				else {
					return false;
				}

				nBytes--;
			}
		}
		else {
			//多字节符的非首字节,应为 10xxxxxx 
			if ((chr & 0xC0) != 0x80) {
				return false;
			}
			//减到为零为止
			nBytes--;
		}
	}

	//违返UTF8编码规则 
	if (nBytes != 0) {
		return false;
	}

	if (bAllAscii) { //如果全部都是ASCII, 也是UTF8
		return true;
	}

	return true;
}

ErrorCodeEnum CUpgradeTaskFSM::UnzipPack(const char* unZipPackName)
{
#ifdef RVC_OS_WIN
	// 设定解压临时目录
	char szOldPath[MAX_PATH] = {};
	GetCurrentDirectoryA(MAX_PATH, szOldPath);

	CSimpleStringA strDownloadsPath;
	ErrorCodeEnum rc = m_pEntity->GetFunction()->GetPath("Downloads",  strDownloadsPath);
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UnzipPack")("unzipPack is fail,get Downloads Path is fail");
		return Error_Unexpect;
	}
	
	CSimpleStringA strZipFile = CSimpleStringA::Format("%s\\%s", strDownloadsPath.GetData(), unZipPackName);
	//升级包是否存在
	if(!ExistsFileA(strZipFile)){
		LogError(Severity_Low, Error_NotExist, 0,  CSimpleStringA::Format("pack [%s] not exists", unZipPackName).GetData());
		return  Error_NotExist;
	}

	CSimpleStringA strUnzipDir;
	strUnzipDir = CSimpleStringA::Format("%s\\%s", strDownloadsPath.GetData(), unZipPackName);
	//解压去除了.zip后缀
	if (strUnzipDir.IsEndWith(".zip")){
		strUnzipDir = strUnzipDir.SubString(0, strUnzipDir.GetLength()-4);
	}
	// 解压目录是否存在，则先删除
	if (ExistsDirA(strUnzipDir.GetData()))
	{
		if(!RemoveDirRecursiveA(strUnzipDir.GetData())){
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UnzipPack")("unzipPack is fail,delete exist temp unzip dir [%s] fail,err=%d",strUnzipDir.GetData(),GetLastError());
			return Error_Unexpect;
		}
	}
	// 创建临时解压目录
	if(!CreateDirectoryA(strUnzipDir.GetData(), NULL)){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UnzipPack")("unzipPack is fail,create temp unzip dir [%s] fail,err=%d",strUnzipDir.GetData(),GetLastError());
		return Error_Unexpect;
	}	
	//设置当前目录为主目录
	if(!SetCurrentDirectoryA(strUnzipDir.GetData())){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UnzipPack")("unzipPack is fail,SetCurrentDirectoryA dir [%s] fail,err=%d",strUnzipDir.GetData(),GetLastError());
		return Error_Unexpect;
	}

	// 解压
	HZIP hz = OpenZip((void*)(const char*)strZipFile,0,ZIP_FILENAME);
	if (hz == 0)
	{
		SetCurrentDirectoryA(szOldPath);
		LogError(Severity_Low, Error_Unexpect, 0,  CSimpleStringA::Format("open zip file [%s] fail", unZipPackName).GetData());
		return  Error_Unexpect;
	}

	ZIPENTRY ze; 
	ZRESULT zrc = GetZipItemA(hz,-1,&ze); 
	if(zrc == ZR_OK){
		int numitems=ze.index;
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UnzipPack")("zip entry count is %d",ze.index);
		for (int i=0; i<numitems; i++)
		{
			zrc = GetZipItemA(hz,i,&ze);
			if(zrc==ZR_OK){
				//兼容压缩包里面中文名称是utf8编码
				if(is_str_utf8(ze.name)){
					char *pGBK = ConvertUtf8ToGBK((const char*)ze.name);
					zrc = UnzipItem(hz,i,pGBK,0,ZIP_FILENAME);
					if(zrc ==ZR_OK){
						//Dbg("unzip [%s] UTF8 item succeed", pGBK);
						delete[] pGBK; 
					}else{
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UnzipPack")("unzip [%s] UTF8 item fail,result=0x%X", pGBK,(int)zrc);
						delete[] pGBK; 
						break;
					}

				}else{
					zrc = UnzipItem(hz,i,ze.name,0,ZIP_FILENAME);
					if(zrc ==ZR_OK){
						//Dbg("unzip [%s] GBK item succeed", ze.name);
					}else{
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UnzipPack")("unzip [%s] GBK item fail,result=0x%X", ze.name,(int)zrc);
						break;
					}
				}
			}else{
				//出错,退出
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("UnzipPack")("unzip GetZipItemA [%d] item fail,fail=0x%X",i,(int)zrc);
				break;
			} 
		}
		CloseZip(hz);
	}else{
		CloseZip(hz);
	}



	// 恢复当前目录 
	SetCurrentDirectoryA(szOldPath);
	if(zrc!=ZR_OK){
		return Error_Exception;
	}
#else

	CSimpleStringA strDownloadsPath;
	ErrorCodeEnum rc = m_pEntity->GetFunction()->GetPath("Downloads", strDownloadsPath);
	if (rc != Error_Succeed) {
		Dbg("unzipPack is fail,get Downloads Path is fail");
		return Error_Unexpect;
	}

	CSimpleStringA strZipFile = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s", strDownloadsPath.GetData(), unZipPackName);
	//升级包是否存在
	if (!ExistsFileA(strZipFile)) {
		LogError(Severity_Low, Error_NotExist, 0, CSimpleStringA::Format("pack [%s] not exists", unZipPackName).GetData());
		return  Error_NotExist;
	}

	CSimpleStringA strUnzipDir;
	strUnzipDir = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s", strDownloadsPath.GetData(), unZipPackName);
	//解压去除了.zip后缀
	if (strUnzipDir.IsEndWith(".zip")) {
		strUnzipDir = strUnzipDir.SubString(0, strUnzipDir.GetLength() - 4);
	}
	// 解压目录是否存在，存在先删除
	if (ExistsDirA(strUnzipDir.GetData()))
	{
		if (!RemoveDirRecursiveA(strUnzipDir.GetData())) {
			Dbg("unzipPack is fail,delete exist temp unzip dir [%s] fail,err=%d", strUnzipDir.GetData(), errno);
			return Error_Unexpect;
		}
	}
	// 创建临时解压目录
	if (!CreateDirA(strUnzipDir.GetData(), false)) {
		// 创建临时解压目录失败
		Dbg("unzipPack is fail,create temp unzip dir [%s] fail,err=%d", strUnzipDir.GetData(), errno);
		return Error_Unexpect;
	}

	if (changeFileAtt(strZipFile.GetData())!=0) {
		//改变文件属性
		Dbg("unzipPack is fail,changeFileAtt zip [%s] fail,err=%d", strZipFile.GetData(), errno);
		return Error_Unexpect;
	}

	// 解压
	string zipFileStr = strZipFile.GetData();
	string zipTempDir = strUnzipDir.GetData();

	if (UnZipToDir(zipFileStr, zipTempDir) != 0)
	{
		LogError(Severity_Low, Error_Unexpect, 0, CSimpleStringA::Format("unzip pack [%s] fail", unZipPackName));
		return  Error_NotExist;
	}
	return Error_Succeed;
#endif
	
}

ErrorCodeEnum CUpgradeTaskFSM::DeleteUnzipDir()
{
	CSimpleStringA strDownloadsPath;
	ErrorCodeEnum rc = m_pEntity->GetFunction()->GetPath("Downloads",  strDownloadsPath);
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DeleteUnzipDir")("DeleteUnzipDir is fail,get Downloads Path is fail");
		return Error_Unexpect;
	}
	//判断解压缩文件夹名是否存在，不存在告警
	if (m_currentTask.pack_name.IsNullOrEmpty()) {
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI("DeleteUnzipDir")("DeleteUnzipDir is fail ,temp unzip dir name is null");
		return Error_Unexpect;
	}
	CSimpleStringA strUnzipDir = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s", strDownloadsPath.GetData(), m_currentTask.pack_name.GetData());
	
	//解压去除了.zip后缀
	if (strUnzipDir.IsEndWith(".zip")){
		strUnzipDir = strUnzipDir.SubString(0, strUnzipDir.GetLength()-4);
	}
	// 解压目录是否存在，存在则删除
	if (ExistsDirA(strUnzipDir.GetData()))
	{
		if(!RemoveDirRecursiveA(strUnzipDir.GetData())){
#ifdef RVC_OS_WIN		
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DeleteUnzipDir")("DeleteUnzipDir fail , temp unzip dir [%s] fail,err=%d",strUnzipDir.GetData(),(int)GetLastError());
#else
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DeleteUnzipDir")("DeleteUnzipDir fail , temp unzip dir [%s] fail,err=%d",strUnzipDir.GetData(), errno);
#endif
			return Error_Unexpect;
		}else{
			return Error_Succeed;
		}
	}
	return Error_Succeed;
}

void CUpgradeTaskFSM::SendUpgradeTaskProgress(CTaskProcess &process)
{
	Json::Value root;
	Json::FastWriter fw;//写入对象
	if(!process.strPackName.IsNullOrEmpty()){
		root["strPackName"]=process.strPackName.GetData();
	}else{
		root["strPackName"]="";
	}

	
	if(process.installVersion.IsNullOrEmpty()){
		root["installVersion"]="0.0.0.0";
	}else{
		root["installVersion"]=process.installVersion.GetData();
	}
	string currentBuildStr = CSimpleStringA::Format("%d.%d.%d",process.CurrentVersion.GetMajor(),process.CurrentVersion.GetMinor(),process.CurrentVersion.GetRevision()).GetData();
	root["CurrentVersion"]=process.CurrentVersion.ToString().GetData();
	root["CurrentBuild"]=currentBuildStr.c_str();	
	root["upgradeTimeStr"]=CSmallDateTime::GetNow().ToTimeString().GetData();

	if(!process.cInstallState.IsNullOrEmpty()){
		root["cInstallState"]=process.cInstallState.GetData();
	}else{
		root["cInstallState"]="";
	}

	if(!process.strInstallComment.IsNullOrEmpty()){
		CSimpleStringA comment = "task:";
		comment.Append(process.strInstallComment.GetData());
		root["strInstallComment"]=comment.GetData();
	}else{
		root["strInstallComment"]="";
	}
	string upgradeStr = fw.write(root);

	if(!upgradeStr.empty()){
		LogWarn(Severity_Low,Error_Succeed,LOG_WRAN_UPGRADE_PROGRESS,upgradeStr.c_str());
	}else{
		LogError(Severity_Middle,Error_Unexpect,ERR_WRAN_UPGRADE_PROGRESS,"获取升级过程信息错误");
	}
}

ErrorCodeEnum CUpgradeTaskFSM::GetRunConfigStrValue(const char *pszSection, const char *pszKey, CSimpleStringA &strValue)
{
	CSmartPointer<IConfigInfo> pConfig;
	ErrorCodeEnum rc = m_pEntity->GetFunction()->OpenConfig(Config_Run, pConfig);
	if (rc != Error_Succeed){
		return rc;
	}
	return pConfig->ReadConfigValue(pszSection, pszKey, strValue);
}

ErrorCodeEnum CUpgradeTaskFSM::SetRunConfigStrValue(const char *pszSection, const char *pszKey, const char *pszValue)
{
	CSmartPointer<IConfigInfo> pConfig;
	ErrorCodeEnum rc = m_pEntity->GetFunction()->OpenConfig(Config_Run, pConfig);
	if (rc != Error_Succeed){
		return rc;
	}
	return pConfig->WriteConfigValue(pszSection, pszKey, pszValue);
}

bool CUpgradeTaskFSM::ClearCurrTaskInfo()
{
	if(SetRunConfigStrValue("upgradeTask","UpgradeTaskId","")!=Error_Succeed){
		return false;
	}
	if(SetRunConfigStrValue("upgradeTask","CreateTaskVersion","")!=Error_Succeed){
		return false;
	}
	if(SetRunConfigStrValue("upgradeTask","PackName","")!=Error_Succeed){
		return false;
	}
	if(SetRunConfigStrValue("upgradeTask","PendingState","")!=Error_Succeed){
		return false;
	}
	if(SetRunConfigStrValue("upgradeTask","NewVersion","")!=Error_Succeed){
		return false;
	}

	//试着删除可能临时下载的升级包文件
	CSimpleStringA strPath;
	ErrorCodeEnum rc = m_pEntity->GetFunction()->GetPath("Downloads", strPath);
	if(Error_Succeed != rc){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ClearCurrTaskInfo")("ClearCurrTaskInfo get Downloads path fail,upgradeTaskId=%s",m_currentTask.upgradeTaskId.GetData());
		return false;
	}
	CSimpleStringA tempPackPath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s%s", strPath.GetData(), m_currentTask.pack_name.GetData(),".tmp");

	if(ExistsFileA(tempPackPath.GetData())){
		if(!RemoveFileA(tempPackPath.GetData())){
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ClearCurrTaskInfo")("ClearCurrTaskInfo delete tempPack fail,packPath=%s",tempPackPath.GetData());
			return false;
		}
	}
	//清空内存变量
	m_currentTask.upgradeTaskId = "";
	m_currentTask.createTaskVersion = "";
	m_currentTask.pack_name = "";
	m_currentTask.cPendingState = "";
	m_currentTask.NewVersion="";

	m_currentTask.pack_version = "";
	m_currentTask.stop_media_play =false;
	m_currentTask.reboot_type = 0;
	m_currentTask.file_path="";
	m_currentTask.download_url = "";
	m_currentTask.pack_hash = "";
	m_currentTask.pack_length = 0;

	//清理安装步骤
	//int iCount = m_currentTask.install_step.size();
	//for (int j = 0; j < iCount; j++){
	//	CInstallStep* tmp = m_currentTask.install_step.front();
	//	m_currentTask.install_step.pop();
	//	delete tmp;//删除对象
	//}
	ClearInstallStep();

	return true;
}

bool CUpgradeTaskFSM::ClearInstallStep()
{
	//清理安装步骤
	int iCount = m_currentTask.install_step.size();
	for (int j = 0; j < iCount; j++){
		CInstallStep* tmp = m_currentTask.install_step.front();
		m_currentTask.install_step.pop();
		delete tmp;//删除对象
	}
	return true;
}

ErrorCodeEnum CUpgradeTaskFSM::LoadPersistTaskInfo()
{
	// 从运行配置中读出上次未处理完的任务
	// 上次未安装结束
	CTaskInfo taskInfo = {};

	CSimpleStringA strValue;
	ErrorCodeEnum rc = GetRunConfigStrValue("upgradeTask", "UpgradeTaskId", strValue);
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("LoadPersistTaskInfo")("recover upgrade state from run config, read [upgradeTask][UpgradeTaskId] fail ，err=%d",(int)rc);
		return rc;
	}
	taskInfo.upgradeTaskId = strValue;


	rc = GetRunConfigStrValue("upgradeTask", "CreateTaskVersion", strValue);
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("LoadPersistTaskInfo")("recover upgrade state from run config, read [upgradeTask][CreateTaskVersion] fail ，err=%d",(int)rc);
		return rc;
	}
	taskInfo.createTaskVersion = strValue;

	rc = GetRunConfigStrValue("upgradeTask", "PackName", strValue);
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("LoadPersistTaskInfo")("recover upgrade state from run config, read [upgradeTask][PackName] fail ，err=%d",(int)rc);
		return rc;
	}
	taskInfo.pack_name = strValue;

	rc = GetRunConfigStrValue("upgradeTask", "PendingState", strValue);
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("LoadPersistTaskInfo")("recover upgrade state from run config, read [upgradeTask][PendingState] fail ，err=%d",(int)rc);
		return rc;
	}
	taskInfo.cPendingState = strValue;

	rc = GetRunConfigStrValue("upgradeTask", "NewVersion", strValue);
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("LoadPersistTaskInfo")("recover upgrade state from run config, read [upgradeTask][NewVersion] fail ，err=%d",(int)rc);
		return rc;
	}
	taskInfo.NewVersion = strValue;

	//初始化其他变量
	//CSimpleStringA pack_version;	//升级包指定的版本号
	//CSimpleStringA to_copy;		//拷贝文件列表
	//CSimpleStringA to_run;		//体系外运行脚本文件名称
	//bool reboot_type;				//重启类型
	//CSimpleStringA download_url;  //升级包下载地址
	//CSimpleStringA pack_hash;		//升级包hash值
	//long pack_length;				//升级包长度


	taskInfo.pack_version = "";
	taskInfo.reboot_type = 0;
	taskInfo.file_path = "";
	taskInfo.download_url = "";
	taskInfo.pack_hash = "";
	taskInfo.pack_length = 0;
	taskInfo.stop_media_play = true;


	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("LoadPersistTaskInfo")("recover upgrade state from run config, UpgradeTaskId=%s", taskInfo.upgradeTaskId.GetData());
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("LoadPersistTaskInfo")("recover upgrade state from run config, CreateTaskVersion=%s",taskInfo.createTaskVersion.GetData());
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("LoadPersistTaskInfo")("recover upgrade state from run config, PackName=%s",taskInfo.pack_name.GetData());
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("LoadPersistTaskInfo")("recover upgrade state from run config, PendingState=%s",taskInfo.cPendingState.GetData());
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("LoadPersistTaskInfo")("recover upgrade state from run config, NewVersion=%s",taskInfo.NewVersion.GetData());



	m_currentTask = taskInfo;

	return Error_Succeed;
}

ErrorCodeEnum CUpgradeTaskFSM::loadCenterCfgInfo()
{
	//访问http地址的读取
	CSmartPointer<IConfigInfo> spConfig;
	ErrorCodeEnum rc = m_pEntity->GetFunction()->OpenConfig(Config_CenterSetting, spConfig);
	if (rc == Error_Succeed){

		CSimpleStringA str="";
		//加载后端服务访问地址
		rc = spConfig->ReadConfigValue("UpgradeManager", "QueryPreTaskUrl", str);
		if(rc==Error_Succeed){
			m_centerUrl.queryPreTaskUrl = str;
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("loadCenterCfgInfo")("init read CenterSetting.ini QueryPreTaskUrl=%s",str.GetData());
		}else{
			LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini QueryPreTaskUrl error");
			return rc;
		}

		rc = spConfig->ReadConfigValue("UpgradeManager", "QueryContinueTaskUrl", str);
		if(rc==Error_Succeed){
			m_centerUrl.queryContinueTaskUrl = str;
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("loadCenterCfgInfo")("init read CenterSetting.ini QueryContinueTaskUrl=%s",str.GetData());
		}else{
			LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini QueryContinueTaskUrl error");
			return rc;
		}


		rc = spConfig->ReadConfigValue("UpgradeManager", "UpdateTaskUrl", str);
		if(rc==Error_Succeed){
			m_centerUrl.updateTaskUrl = str;
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("loadCenterCfgInfo")("init read CenterSetting.ini UpdateTaskUrl=%s",str.GetData());
		}else{
			LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini UpdateTaskUrl error");
			return rc;
		}

		rc = spConfig->ReadConfigValue("UpgradeManager", "QueryCurrTaskUrl", str);
		if(rc==Error_Succeed){
			m_centerUrl.queryCurrTaskUrl = str;
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("loadCenterCfgInfo")("init read CenterSetting.ini QueryCurrTaskUrl=%s",str.GetData());
		}else{
			LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini QueryCurrTaskUrl error");
			return rc;
		}

		rc = spConfig->ReadConfigValue("UpgradeManager", "QueryNewTaskUrl", str);
		if(rc==Error_Succeed){
			m_centerUrl.queryNewTaskUrl = str;
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("loadCenterCfgInfo")("init read CenterSetting.ini QueryNewTaskUrl=%s",str.GetData());
		}else{
			LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini QueryNewTaskUrl error");
			return rc;
		}

		rc = spConfig->ReadConfigValue("UpgradeManager", "QueryTaskStatus", str);
		if(rc==Error_Succeed){
			m_centerUrl.queryTaskStatus = str;
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("loadCenterCfgInfo")("init read CenterSetting.ini QueryTaskStatus=%s",str.GetData());
		}else{
			LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini QueryTaskStatus error");
			return rc;
		}

		rc = spConfig->ReadConfigValue("UpgradeManager", "SendSM3TaskUrl", str);
		if(rc==Error_Succeed){
			m_centerUrl.sendSM3TaskUrl = str;
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("loadCenterCfgInfo")("init read CenterSetting.ini SendSM3TaskUrl=%s",str.GetData());
		}else{
			LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini SendSM3TaskUrl error");
			return rc;
		}
		//加载下载分段切片长度值（单位M）
		rc = spConfig->ReadConfigValue("UpgradeManager", "EachDownloadLen", str);
		if(rc==Error_Succeed){
			if(str.IsNullOrEmpty()){
				m_eachDownloadLen = DOWNLOAD_CONTENT_EACH_LEN;
			}else{
				m_eachDownloadLen = atoi(str.GetData())*1024*1024;
			}
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("loadCenterCfgInfo")("init read CenterSetting.ini EachDownloadLen=%s m",str.GetData());
		}else{
			LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini EachDownloadLen error");
			return rc;
		}
		//新的下载分段切片长度值（单位K）
		rc = spConfig->ReadConfigValue("UpgradeManager", "NewEachDownloadLen", str);
		if(rc==Error_Succeed){
			if(str.IsNullOrEmpty()){
				m_newEachDownloadLen = DOWNLOAD_CONTENT_EACH_LEN;
			}else{
				if(atoi(str.GetData())>16){
					m_newEachDownloadLen = atoi(str.GetData())*1024;
				}else{
					m_newEachDownloadLen = 16*1024;//设置默认最小值
				}
				
			}
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("loadCenterCfgInfo")("init read CenterSetting.ini NewEachDownloadLen=%s K",str.GetData());
		}else{
			LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini NewEachDownloadLen error");
			return rc;
		}
		//加载是否打印http通讯日志
		int printlogInt =0;
		rc = spConfig->ReadConfigValueInt("UpgradeManager", "PrintLog", printlogInt);
		if(rc==Error_Succeed){
			if(printlogInt==0){
				m_PrintHttpLog = false;
			}else{
				m_PrintHttpLog = true;
			}
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("loadCenterCfgInfo")("init read CenterSetting.ini PrintLog=%d",printlogInt);
		}else{
			LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini PrintLog error");
			return rc;
		}
		int startFlagInt =0;
		rc = spConfig->ReadConfigValueInt("UpgradeManager", "StartFlag", startFlagInt);
		if(rc==Error_Succeed){
			if(startFlagInt==0){
				m_startFlag = false;
			}else{
				m_startFlag = true;
			}
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("loadCenterCfgInfo")("init read CenterSetting.ini StartFlag=%d",startFlagInt);
		}else{
			LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini StartFlag error");
			return rc;
		} 

		//加载扫描hash配置文件列表
		rc = spConfig->ReadConfigValue("UpgradeManager", "relativeDir", str);
		if(rc==Error_Succeed){
			m_hashScanSet.relativeDir = str;
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("loadCenterCfgInfo")("init read CenterSetting.ini relativeDir=%s",str.GetData());
		}else{
			LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini relativeDir error");
			return rc;
		}
		rc = spConfig->ReadConfigValue("UpgradeManager", "absoluteDir", str);
		if(rc==Error_Succeed){
			m_hashScanSet.absoluteDir = str;
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("loadCenterCfgInfo")("init read CenterSetting.ini absoluteDir=%s",str.GetData());
		}else{
			LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini absoluteDir error");
			return rc;
		}
		rc = spConfig->ReadConfigValue("UpgradeManager", "currVerDir", str);
		if(rc==Error_Succeed){
			m_hashScanSet.currVerDir = str;
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("loadCenterCfgInfo")("init read CenterSetting.ini currVerDir=%s",str.GetData());
		}else{
			LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini currVerDir error");
			return rc;
		}
		rc = spConfig->ReadConfigValue("UpgradeManager", "blackFile", str);
		if(rc==Error_Succeed){
			m_hashScanSet.blackFile = str;
			CAutoArray<CSimpleStringA> arr = str.Split('|');
			for(int i=0; i< arr.GetCount(); i++)
			{
				m_FileBlacklist.push_back(arr[i]);
			}
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("loadCenterCfgInfo")("init read CenterSetting.ini blackFile=%s",str.GetData());
		}else{
			LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini blackFile error");
			return rc;
		}
		rc = spConfig->ReadConfigValue("UpgradeManager", "blackDir", str);
		if(rc==Error_Succeed){
			m_hashScanSet.blackDir = str;
			CAutoArray<CSimpleStringA> arr = str.Split('|');
			for(int i=0; i< arr.GetCount(); i++)
			{
				m_DirBlacklist.push_back(arr[i]);
			}
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("loadCenterCfgInfo")("init read CenterSetting.ini blackDir=%s",str.GetData());
		}else{
			LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini blackDir error");
			return rc;
		}

	}else{
		LogWarn(Severity_Middle, rc, ERR_TASK_READ_INI_FAIL,  "get CenterSetting.ini error");
		return rc;
	}
	return Error_Succeed;
}

bool CUpgradeTaskFSM::GetFileLength(const char* filePath,long &fileLen)
{
	FILE* file = fopen(filePath, "rb");  
	if (file!=NULL)  
	{  
#ifdef RVC_OS_WIN
		fileLen = filelength(fileno(file));  
		fclose(file);  
		return true;
#else
		if (fseek(file, 0, SEEK_END)!=0) {
			Dbg("GetFileLength fseek is error,%s",strerror(errno));
			fclose(file);
			fileLen = 0;
			return false;
		}  
		fileLen = ftell(file); ///求出当前文件指针距离文件开始的字节数
		if (fileLen == -1) {
			Dbg("GetFileLength ftell is error,%s", strerror(errno));
			fclose(file);
			fileLen = 0;
			return false;
		}
		else {
			fclose(file);
			return true;
		}

#endif
	} else{
		fileLen = 0;
		return false;
	}

	
	return true;


}

ErrorCodeEnum CUpgradeTaskFSM::GetSM3List(CSimpleStringA &strSM3List)
{
	if (!m_fileSM3List.IsNullOrEmpty())
	{
		strSM3List = m_fileSM3List;
		return Error_Succeed;
	}

	m_fileSM3Map.clear();//生成文件hash列表前先清空
	
	//根据配置项开始扫描文件和计算hash
	ErrorCodeEnum rc = Error_Succeed ;
	if(!m_hashScanSet.absoluteDir.IsNullOrEmpty()){
		//绝对路径扫描
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetSM3List")("GetSM3List scan absoluteDir=%s",m_hashScanSet.absoluteDir.GetData());
		rc = ScanSM3ByType(1,m_hashScanSet.absoluteDir);
		if(rc!=Error_Succeed){
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetSM3List")("GetMD5List fail ,scan absoluteDir is fail");
			return rc;
		}
	}

	if(!m_hashScanSet.relativeDir.IsNullOrEmpty()){
		//相对路径扫描
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetSM3List")("GetSM3List scan relativeDir=%s",m_hashScanSet.relativeDir.GetData());
		ScanSM3ByType(2,m_hashScanSet.relativeDir);
		if(rc!=Error_Succeed){
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetSM3List")("GetMD5List fail ,scan relativeDir is fail");
			return rc;
		}
	}

	if(!m_hashScanSet.currVerDir.IsNullOrEmpty()){
		//当前版本扫描
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetSM3List")("GetSM3List scan currVerDir=%s",m_hashScanSet.currVerDir.GetData());
		ScanSM3ByType(3,m_hashScanSet.currVerDir);
		if(rc!=Error_Succeed){
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetSM3List")("GetMD5List fail ,scan currVerDir is fail");
			return rc;
		}
	}

	if(m_iBlackFileCount>50){
		LogWarn(Severity_Low, rc, WARN_BLACK_FILE_SUM,  CSimpleStringA::Format("get MD5List black file count=%d",m_iBlackFileCount));
	}
	m_iBlackFileCount=0;

	for(auto it=m_fileSM3Map.begin(); it!=m_fileSM3Map.end(); it++)
	{
		strSM3List += it->first;
		strSM3List += ",";
		strSM3List += it->second;
		strSM3List += ";";
	}

	m_fileSM3List = strSM3List;

	return Error_Succeed;
}

ErrorCodeEnum CUpgradeTaskFSM::ScanSM3ByType(int type,CSimpleStringA pathFilter)
{
	if(!pathFilter.IsNullOrEmpty()){

		CSimpleStringA rootPath;//根路径
		CSimpleStringA replacePath;//替换路径
		CSimpleStringA currPath;//当前版本路径

		CSimpleStringA tempPath ="";
		ErrorCodeEnum Error =m_pEntity->GetFunction()->GetPath("Root",tempPath);//例如：C:\Run  /opt/Run
		if(Error_Succeed == Error){
			if(!tempPath.IsNullOrEmpty()){
				string runPathStr = tempPath.GetData();
				int pos = runPathStr.find_last_of(SPLIT_SLASH);
				rootPath = runPathStr.substr(0,pos).c_str();
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ScanSM3ByType")("ScanSM3ByType get Root path is null");
				return Error_Null;
			}
		}else{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ScanSM3ByType")("ScanSM3ByType get Root path is error");
			return Error;
		}

		CSimpleStringA tempCurrPath = "";
		Error =m_pEntity->GetFunction()->GetPath("Base",tempCurrPath);//例如：C:\Run\version\4.8.1.1  /opt/Run/version/4.8.1.1
		if(Error_Succeed == Error){
			if(!tempCurrPath.IsNullOrEmpty()){
				currPath = tempCurrPath;
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ScanSM3ByType")("ScanSM3ByType get currVer path is null");
				return Error_Null;
			}
		}else{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ScanSM3ByType")("ScanSM3ByType get currVer path is error");
			return Error;
		}


		//路径扫描
		CAutoArray<CSimpleStringA> copyList = pathFilter.Split('|');
		for(int i=0; i<copyList.GetCount(); i++)
		{
			CSimpleStringA file = copyList[i];
#ifdef RVC_OS_WIN
#else
			//UOS把路径改为反斜杠
			string replaceStr = file.GetData();
			std::replace(replaceStr.begin(), replaceStr.end(), '\\', '/');
			file = replaceStr.c_str();
#endif
			if(file.IsNullOrEmpty()){
				continue;
			}else{
				//构造扫描的绝对路径
				CSimpleStringA scanFilter = "";
				CSimpleStringA replaceDir = "";
				if(type==1){
					//绝对路径
					scanFilter = file;
					replaceDir = GetFileDirectory(file.GetData());
				}else if(type==2){
					//相对路径
					scanFilter = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",rootPath.GetData(),file.GetData());
					replaceDir = GetFileDirectory(file.GetData());
				}else if(type==3){
					//当前版本路径:特殊处理下替换路径为Run\version\4.8.1.1
					scanFilter = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",currPath.GetData(),file.GetData());
					CSimpleStringA temp = scanFilter.SubString(rootPath.GetLength()+1,scanFilter.GetLength()-(rootPath.GetLength()+1));
					replaceDir = GetFileDirectory(temp.GetData());
				}
				//替换路径前缀
				ErrorCodeEnum ret = NewSM3Folder(scanFilter,replaceDir);
				if(ret!=Error_Succeed){
					return ret;
				}
			}
		}
	}
	return Error_Succeed;
}

ErrorCodeEnum CUpgradeTaskFSM::NewSM3Folder(CSimpleStringA scanFilter,CSimpleStringA replaceDir)
{
	if(scanFilter.IsNullOrEmpty()){
		return Error_Succeed;
	}
	//DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("NewSM3Folder")("scan file scanFilter is %s",scanFilter.GetData());
	//通配符
	if(scanFilter.IndexOf("*")>0){
		//找到要扫描的文件夹
		CSimpleStringA strFileDir = GetFileDirectory(scanFilter.GetData());
		//过滤通配条件
		CSimpleStringA strFileFilter = _GetFileName(scanFilter.GetData());
		list<CSimpleStringA> fileList;
		//获取所有根文件夹下的文件相对路径：如mod\test.dll
		RecursiveGetSubFiles(strFileDir.GetData(), strFileDir.GetData(), fileList);
		for(auto it = fileList.begin(); it != fileList.end(); it++)
		{
			
			CSimpleStringA tempFile = *it;
			if (IsFileMatch(strFileFilter, _GetFileName(tempFile.GetData())))
			{
				CSimpleStringA tempFullName = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",strFileDir.GetData(),tempFile.GetData());
				CSimpleStringA tempFileName = _GetFileName(tempFile.GetData());
				CSimpleStringA tempFileDir = GetFileDirectory(tempFile.GetData());
				//整个黑名单文件过滤
				bool isBlackFile = false;
				list<CSimpleStringA>::iterator itorFile = m_FileBlacklist.begin();
				while(itorFile!=m_FileBlacklist.end())
				{
					CSimpleStringA fileBlack =  *itorFile;
					//if(tempFileName.IsEndWith(fileBlack.GetData(),true)){
					//	isBlackFile=true;
					//	break;
					//}
					if(IsFileMatch(fileBlack.GetData(),tempFileName.GetData())){
						isBlackFile=true;
						break;
					}
					itorFile++;
				}
				if(isBlackFile){
					//DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("NewSM3Folder")("BlackFile Filter don't add to md5 list, file = [%s]", tempFullName.GetData());
					m_iBlackFileCount++;
					continue;
				}
				//整个黑名单文件夹过滤
				bool isBlackDir = false;
				list<CSimpleStringA>::iterator itorDir = m_DirBlacklist.begin();
				while(itorDir!=m_DirBlacklist.end())
				{
					CSimpleStringA dirBlack =  *itorDir;
					if(tempFileDir.IndexOf(dirBlack.GetData())>0){
						isBlackDir=true;
						break;
					}
					itorDir++;
				}

				if(isBlackDir){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("NewSM3Folder")("BlackDir Filter don't add to md5 list, dir = [%s]", tempFullName.GetData());
					continue;
				}
				//计算hash值，加入到hash列表
				CSimpleStringA strMD5Val;
				ErrorCodeEnum rErrcode = SM3FileToStr(tempFullName, strMD5Val,false);
				if (Error_Succeed != rErrcode)
				{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("NewSM3Folder")("%s get sm3 fail ,error:%d", tempFullName.GetData(), (int)rErrcode);
					return rErrcode;
				}
				CSimpleStringA relativePath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",replaceDir.GetData(),tempFile.GetData());
				//Dbg("scan file succ [%s]",relativePath.GetData());
				m_fileSM3Map[relativePath] = strMD5Val;
				Sleep(100);//时间片
			}
		}
	}else{
		if(ExistsFileA(scanFilter.GetData())){
			//整个黑名单文件过滤
			bool isBlackFile = false;
			CSimpleStringA tempFileName = _GetFileName(scanFilter.GetData());//文件名称
			CSimpleStringA tempFileDir = GetFileDirectory(scanFilter.GetData());//文件夹名称
			list<CSimpleStringA>::iterator itorFile = m_FileBlacklist.begin();
			while(itorFile!=m_FileBlacklist.end())
			{
				CSimpleStringA fileBlack =  *itorFile;
				//if(scanFilter.IsEndWith(fileBlack.GetData(),true)){
				//	isBlackFile=true;
				//	break;
				//}						
				if(IsFileMatch(fileBlack.GetData(),tempFileName.GetData())){
					isBlackFile=true;
					break;
				}
				itorFile++;
			}
			if(isBlackFile){
				//DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("NewSM3Folder")("BlackFile Filter don't add to md5 list, file = [%s]", scanFilter.GetData());
				m_iBlackFileCount++;
			}
			//整个黑名单文件夹过滤
			bool isBlackDir = false;
			list<CSimpleStringA>::iterator itorDir = m_DirBlacklist.begin();
			while(itorDir!=m_DirBlacklist.end())
			{
				CSimpleStringA dirBlack =  *itorDir;
				if(tempFileDir.IndexOf(dirBlack.GetData())>0){
					isBlackDir=true;
					break;
				}
				itorDir++;
			}
			if(isBlackDir){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("NewSM3Folder")("BlackDir Filter don't add to md5 list, dir = [%s]", scanFilter.GetData());
			}

			if(!isBlackDir&&!isBlackFile){
				//加入hash列表
				CSimpleStringA strMD5Val;
				ErrorCodeEnum rErrcode = SM3FileToStr(scanFilter, strMD5Val,false);
				if (Error_Succeed != rErrcode)
				{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("NewSM3Folder")("%s get sm3 fail ,error:%d", scanFilter.GetData(), (int)rErrcode);
					return rErrcode;
				}
				CSimpleStringA tempFileName = _GetFileName(scanFilter.GetData());
				CSimpleStringA relativePath = CSimpleStringA::Format("%s" SPLIT_SLASH_STR "%s",replaceDir.GetData(),tempFileName.GetData());
				//Dbg("scan file succ [%s]",relativePath.GetData());
#ifdef RVC_OS_WIN
#else
				Sleep(100);//加入时间碎片
#endif
				m_fileSM3Map[relativePath] = strMD5Val;
			}
		}
	}

	return Error_Succeed;
}

ErrorCodeEnum CUpgradeTaskFSM::SM3FileToStr(CSimpleStringA strFilePath, CSimpleStringA &strSM3,bool isSub)
{
	if(strFilePath.IsNullOrEmpty()){
		return Error_Null;
	}
	int nlen = strlen(strFilePath.GetData());
	char* pchar = new char[nlen+1];
	strcpy(pchar,strFilePath.GetData());
	BYTE md5[32]={0};
	try
	{
		if(SM3File(pchar,md5)){
			delete[] pchar;
			//获取16进制的字符串
			if(Error_Succeed!=SM3_Str(strSM3,md5,isSub)){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("SM3FileToStr")("sm3 to hex str fail,file=%s",strFilePath.GetData());
				return Error_Unexpect;
			}		
			return Error_Succeed;
		}else{
			delete[] pchar;
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("SM3FileToStr")("sm3 encrypt fail ,file=%s",strFilePath.GetData());
			return Error_Unexpect;
		}
	}
	catch (...)
	{
		delete[] pchar;
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("SM3FileToStr")("sm3 encrypt exception ,file=%s",strFilePath.GetData());
		return Error_Exception;
	}

}

ErrorCodeEnum CUpgradeTaskFSM::SM3DataToStr(CSimpleStringA strData, CSimpleStringA &strSM3,bool isSub)
{
	if(strData.IsNullOrEmpty()){
		return Error_Null;
	}
	BYTE md5[32]={0};
	try
	{
		if(SM3Hash((BYTE*)strData.GetData(),strlen(strData.GetData()),md5)){
			//获取16进制的字符串
			if(Error_Succeed!=SM3_Str(strSM3,md5,isSub)){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("SM3DataToStr")("sm3 to hex str fail");
				return Error_Unexpect;
			}	
			return Error_Succeed;
		}else{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("SM3DataToStr")("sm3 encrypt fail");
			return Error_Unexpect;
		}
	}
	catch (...)
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("SM3DataToStr")("sm3 encrypt exception");
		return Error_Exception;
	}
}

ErrorCodeEnum CUpgradeTaskFSM::SM3_Str(CSimpleStringA &strSM3,BYTE * SM3Byte,bool isSub)
{
	if(SM3Byte == NULL){
		return Error_Exception;
	}
	int SM3_len=64;
	if(isSub){
		SM3_len=32;
	}
	int i; 
	char* file_SM3 = (char*)malloc((SM3_len + 1) * sizeof(char)); 
	if(file_SM3 == NULL)  
	{  
		fprintf(stderr, "SM3 malloc failed.\n");  
		return Error_Exception;  
	} 
	memset(file_SM3, 0, (SM3_len + 1));  

	if(SM3_len == 32)  
	{  
		for(i=0; i<16; i++)  
		{   //SM3截取中间16位字节，8-24位字节数，小写
			sprintf(&file_SM3[i*2], "%02x", SM3Byte[i+8]);  
		}  
	}  
	else if(SM3_len == 64)  
	{  
		for(i=0; i<32; i++)  
		{  
			sprintf(&file_SM3[i*2], "%02x", SM3Byte[i]);  
		}  
	}    

	strSM3=file_SM3;  
	free(file_SM3);
	return Error_Succeed;
}

bool CUpgradeTaskFSM::IsPackDownloaded(const char *packPath,const char* packHash,long packLen)
{
	if(!ExistsFileA(packPath)){
		return false;//文件不存在，下载
	}
	//计算hash值
	CSimpleStringA strMD5Val;
	ErrorCodeEnum rc = SM3FileToStr(packPath, strMD5Val,false);
	if (Error_Succeed != rc)
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("IsPackDownloaded")("%s get download pack sm3 fail ,error:%d", packPath, (int)rc);
		return false;//获取hash码失败，下载
	}
	//不区分大小写比较文件hash
#ifdef RVC_OS_WIN
	if(stricmp(strMD5Val.GetData(),packHash)==0){
#else
	if(strcmp(strMD5Val.GetData(),packHash)==0){
#endif
		return true;//相同，不下载
	}else{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("IsPackDownloaded")("%s sm3[%s] is no equal upgrade sm3[%s], retry download.", packPath, strMD5Val.GetData(), packHash);
		return false;//不相同，下载
	}
}

bool CUpgradeTaskFSM::DownloadFileWrite(byte* content,long contentLen,const char* filePath)
{
	if(contentLen==0){
		return true;
	}
	FILE* tempFp =  fopen(filePath,"ab");
	if(tempFp==NULL){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadFileWrite")("DownloadFileWrite open file fail");
		return false;
	}
	int ret = fwrite(content,(size_t)contentLen,1,tempFp);

	fclose(tempFp);

	if(ret!=1){
#ifdef RVC_OS_WIN
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadFileWrite")("DownloadFileWrite write file fail,ret = %d,errno = %d",ret,(int)GetLastError());
		return false;
#else
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadFileWrite")("DownloadFileWrite write file fail,ret = %d,errno = %d",ret, errno);
		return false;
#endif		
	}
	return true;
}

bool CUpgradeTaskFSM::CheckIfCanSwitchNow()
{
	//对于终端初始化安装时，直接通过。
	if (isTerminalInstall()) {
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("CheckIfCanSwitchNow")("CheckIfCanSwitchNow terminal new install,return true");
		return true;
	}
	//非重启操作,则直接可以进行切换，不用等待时机
	if(m_currentTask.reboot_type == 0){
		return true;
	}
	CSimpleStringA strCustomerHandle;
	CSimpleStringA strCallState;


	// 无交互N、客户关注A、客户在控制终端C、柜员协助T、柜员代操作G
	ErrorCodeEnum rc = m_pEntity->GetFunction()->GetSysVar("CustomerHandle", strCustomerHandle);
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CheckIfCanSwitchNow")("CheckIfCanSwitchNow get CustomerHandle value is fail ,err=%d",(int)rc);
		return false;
	}

	// 离线O、尝试连线柜员C、免提通话H、连线失败F、断线B
	rc = m_pEntity->GetFunction()->GetSysVar("CallState", strCallState);
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CheckIfCanSwitchNow")("CheckIfCanSwitchNow get CallState value is fail ,err=%d",(int)rc);
		return false;
	}

#ifdef RVC_OS_WIN
	SYSTEMTIME st = {};
	GetLocalTime(&st);
	//DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CheckIfCanSwitchNow")("hour is %d",(int)st.wHour);
	bool bOffworkTime = st.wHour < 8 || st.wHour >= 21;
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CheckIfCanSwitchNow")("hour is %d, strCustomerHandle=%s, strCallState=%s, bOffworkTime=%d",(int)st.wHour,strCustomerHandle.GetData(),strCallState.GetData(),(int)bOffworkTime);
#else
	time_t nowTime = time(NULL);
	tm nowTimeTm = { 0 };
	localtime_r(&nowTime, &nowTimeTm);
	//Dbg("hour is %d", (int)nowTimeTm.tm_hour);
	bool bOffworkTime = nowTimeTm.tm_hour < 8 || nowTimeTm.tm_hour >= 21;
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("CheckIfCanSwitchNow")("hour is %d, strCustomerHandle=%s, strCallState=%s, bOffworkTime=%d",(int)nowTimeTm.tm_hour,strCustomerHandle.GetData(),strCallState.GetData(),(int)bOffworkTime);
#endif


	// 或者下班时间且非连线状态 @20151202
	// 客户关注状态A，不允许切换 by zl 20191113
	if (strCustomerHandle[0] == 'N' || (bOffworkTime && strCallState[0] == 'O')) {
		return true;
	}
	else {
		// 防止感知一直误报有人状态，加入以下特例：如果是一天当中首次从切换状态直接跳转过来的升级切换，并且当前是首页则进行切换
		if (!bOffworkTime) {
			CSimpleStringA strUIState;
			// M 首页
			rc = m_pEntity->GetFunction()->GetSysVar("UIState", strUIState);
			if (rc != Error_Succeed) {
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("CheckIfCanSwitchNow")("CheckIfCanSwitchNow get strUIState value is fail ,err=%d", (int)rc);
				return false;
			}
#ifdef RVC_OS_WIN
			CSimpleStringA  nowStr = CSimpleStringA::Format("%d-%d-%d", st.wYear, st.wMonth, st.wDay).GetData();
#else
			CSimpleStringA  nowStr = CSimpleStringA::Format("%d-%d-%d", nowTimeTm.tm_year+1900, nowTimeTm.tm_mon+1, nowTimeTm.tm_mday).GetData();
#endif
			//读取强制切换的日期
			CSimpleStringA ForceSwitchDateStr = "";
			ErrorCodeEnum rc = GetRunConfigStrValue("upgradeTask", "ForceSwitchDate", ForceSwitchDateStr);
			if (rc != Error_Succeed) {
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("CheckIfCanSwitchNow")("CheckIfCanSwitchNow read from run config, read [upgradeTask][ForceSwitchDate] fail ，err=%d", (int)rc);
				return false;
			}

			//首页并且切换状态直接进入
			if (strUIState.Compare("M") == 0 && m_bSwitchFlag) {
				//当天是否切换过
				if (ForceSwitchDateStr.Compare(nowStr.GetData()) == 0) {
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("CheckIfCanSwitchNow")("CheckIfCanSwitchNow is not ForceSwitch, ForceSwitchDate[%s]", ForceSwitchDateStr.GetData());
					return false;
				}
				else {
					//直接切换,并写入强制切换日期
					if (SetRunConfigStrValue("upgradeTask", "ForceSwitchDate", nowStr.GetData()) != Error_Succeed) {
						DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("CheckIfCanSwitchNow")("CheckIfCanSwitchNow write run config, write [upgradeTask][ForceSwitchDate] fail[%s]，err=%d", nowStr.GetData(), (int)rc);
					}
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("CheckIfCanSwitchNow")("CheckIfCanSwitchNow ForceSwitch, ForceSwitchDate[%s]", nowStr.GetData());
					return true;
				}
			}
			else {
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("CheckIfCanSwitchNow")("CheckIfCanSwitchNow is not ForceSwitch, UIState=%s,m_bSwitchFlag=%d", strUIState.GetData(),(int)m_bSwitchFlag);
				return false;
			}
		}
		else {
			return false;
		}
	}
}

ErrorCodeEnum CUpgradeTaskFSM::SwitchUpgradeNow()
{
	//默认轻量包不重启系统和框架，体系外系统不重启系统，系统升级重启框架
	//根据重启策略类型去重启 
	//重启策略类型（0:不启动 1:重启框架 2:重启系统）
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("SwitchUpgradeNow")("begin SwitchUpgradeNow");
	if(m_currentTask.reboot_type == 0){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("SwitchUpgradeNow")("upgrade to new version [%s] succeed, taskID=[%s] ", m_currentVersion.ToString().GetData(),m_currentTask.upgradeTaskId.GetData());
		PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartDealTask));//进入S2

	}else if(m_currentTask.reboot_type == 1){

		if(m_currentTask.NewVersion.IsNullOrEmpty()){
			//非版本升级
			LogEvent(Severity_Middle, Event_Req_Framework_No_Upgrade_Restart, 
				CSimpleStringA::Format("upgrade to new version [%s] succeed, request to no upgrade restart framework , taskID=[%s]", m_currentTask.NewVersion.GetData(), m_currentTask.upgradeTaskId.GetData()));
			PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_PreRestart));//进入S7
		}else{
			//版本升级，健康有后续回退处理
			LogEvent(Severity_Middle, Event_Req_Framework_Restart, 
				CSimpleStringA::Format("upgrade to new version [%s] succeed, request to restart framework , taskID=[%s]", m_currentTask.NewVersion.GetData(), m_currentTask.upgradeTaskId.GetData()));
			PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_PreRestart));//进入S7
		}


	}else if(m_currentTask.reboot_type == 2){

		LogEvent(Severity_Middle, Event_Req_OS_Restart, 
			CSimpleStringA::Format("SysPackInstall upgrade to new version [%s] succeed, request to restart OS, taskID=[%s]", m_currentVersion.ToString().GetData(), m_currentTask.upgradeTaskId.GetData()));
		PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_PreRestart));//进入S7

	}else{
	
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("SwitchUpgradeNow")("reSetType=[%d] is invalid ,upgrade to new version [%s] fail, taskID=[%s]",m_currentTask.reboot_type, m_currentVersion.ToString().GetData(), m_currentTask.upgradeTaskId.GetData());
		PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartDealTask));//进入S2

	}

	// 强制刷新日志
	m_pEntity->GetFunction()->FlushLogFile();

	return Error_Succeed;
}

ErrorCodeEnum CUpgradeTaskFSM::DownloadProgress(long tempFileLen,long fileSumLen)
{
	UpgradeDownloadProgress dProgress;
	dProgress.currentFile = m_currentTask.pack_name;
	dProgress.fileNum = 1;
	dProgress.progress=0;
	if(fileSumLen!=0){
		//DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadProgress")("tempFileLen =%d , fileSumLen =%d",tempFileLen,fileSumLen);
		dProgress.progress = (int)(tempFileLen/(fileSumLen/100));
		if(dProgress.progress ==10||dProgress.progress ==20||dProgress.progress ==30||dProgress.progress ==40||dProgress.progress ==50
			||dProgress.progress ==60||dProgress.progress ==70||dProgress.progress ==80||dProgress.progress ==90)
		{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadProgress")("download progress is %d ,tempFileLen =%d , fileSumLen =%d",dProgress.progress,tempFileLen,fileSumLen);	
		}
		//Dbg("download file [%s] progress is %d",dProgress.currentFile.GetData(),dProgress.progress);
		ErrorCodeEnum retError = SpSendBroadcast(GetEntityBase()->GetFunction(), SP_MSG_OF(UpgradeDownloadProgress), SP_MSG_SIG_OF(UpgradeDownloadProgress), dProgress);
		return retError;
	}else{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("DownloadProgress")("download file [%s] progress is fail,sumlen=0");
		return Error_Exception;
	}
	
}

char CUpgradeTaskFSM::GetInstallState(int nState)
{
	if (nState == s4)
		return 'U';
	else if (nState == s5)
		return 'I';
	else if (nState == s6)
		return 'S';
	else 
		return 'N';
}

ErrorCodeEnum CUpgradeTaskFSM::GetUpgradeState(bool &bInstalling, CSimpleStringA &strPackFile, CSimpleStringA &strExecID, char &cInstallState, bool &bSysInstall, bool &bLightPack, CSimpleStringA &strNewVersion)
{
	bInstalling = !m_currentTask.upgradeTaskId.IsNullOrEmpty();
	if (bInstalling)
	{
		strPackFile = m_currentTask.pack_name;
		strExecID = m_currentTask.upgradeTaskId;
		cInstallState = GetInstallState(m_iState);
		bSysInstall = false;
		bLightPack = false;
		//if(!m_currentTask.to_run.IsNullOrEmpty()){
		//	bSysInstall = true;
		//}else{
		//	bSysInstall = false;
		//}
		//if(m_currentTask.pack_version.IsNullOrEmpty()){
		//	bLightPack = true;
		//}else{
		//	bLightPack = false;
		//}
		strNewVersion = m_currentTask.NewVersion;
	}
	return Error_Succeed;
}

void CUpgradeTaskFSM::HttpsLogCallBack(const char* logtxt)
{
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("HttpsLogCallBack")("http dbg: %s",logtxt);
}

bool CUpgradeTaskFSM::isWork()
{
	//兜底方案是判断集中配置一个参数，去除其他变量的判断，但是容易出现任务状态更新不准的情况。
	if(m_startFlag){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("isWork")("upgrade startFlag is true");
		return true;
	}
	//判断是否在设备安装状态，不受一般升级影响
	if (isTerminalInstall()) {
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("isWork")("isTerminalInstall get TerminalStage is N");
		return true;
	}
	else {
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("isWork")("isTerminalInstall get TerminalStage is not N");
	}
	
	//判断升级实体是否工作
	//1.当有版本升级任务时，判断是否处于Guardian升级回退过程，如果已经升级成功或者回退成功，则开始工作，否则等待中
	//2.当无任务或者非版本升级任务时，判断TerminalStage这个变量，非X状态，当A状态并且进入首页，则开始工作
	
	//升级任务
	if((!m_currentTask.NewVersion.IsNullOrEmpty())&&(m_currentTask.cPendingState=="T"||m_currentTask.cPendingState=="C"||m_currentTask.cPendingState=="X")){
		CSimpleStringA strRunInfo,strStartTime;
		if (m_pEntity->GetFunction()->GetPath("RunInfo",strRunInfo) == Error_Succeed){
#ifdef RVC_OS_WIN
			strStartTime = strRunInfo + "\\runcfg\\starttime.dat";
#else
			strStartTime = strRunInfo + "/runcfg/starttime.dat";
#endif
			if(!ExistsFileA(strStartTime.GetData())){
				return true;//完成升级过程，通过
			}else{
#ifdef RVC_OS_WIN
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("isWork")("upgrade process is not end ,file \\runcfg\\starttime is exist");
#else
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("isWork")("upgrade process is not end ,file /runcfg/starttime is exist");
#endif
				return false;//继续等待
			}
		}else{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("isWork")("upgrade process is not end ,get runinfo path is error");
			return false;//失败,继续等待
		}
	}

	//非升级任务和无任务
	CSimpleStringA strValue;
	if(m_pEntity->GetFunction()->GetSysVar("TerminalStage", strValue) == Error_Succeed){
		if(strValue.Compare("X")==0){	
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("isWork")("TerminalStage = X ,continue wait");
			return false;//状态是x继续等待
		}
		if(strValue.Compare("A")==0){
			if(((CUpgradeMgrEntity*)m_pEntity)->m_bStartUp){
				return true;//通过
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("isWork")("TerminalStage = A ,but UIState is not M , continue wait");
				return false;//准入过，但进入首页，继续等待
			}
		}
		return true;//剩余其他状态都可以通过
	}else{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("isWork")("get TerminalStage is error , continue wait");
		return false;//失败,继续等待
	}
}

bool CUpgradeTaskFSM::isAuthSucc() {
	CSimpleStringA strValue;
	if (m_pEntity->GetFunction()->GetSysVar("TerminalStage", strValue) == Error_Succeed) {
		if (strValue.Compare("A") == 0) {
			return true;
		}
		else {
			return false;
		}
	}
	else {
		return false;
	}
}

bool CUpgradeTaskFSM::isTerminalInstall() {
	CSimpleStringA strValue;
	if (m_pEntity->GetFunction()->GetSysVar("TerminalStage", strValue) == Error_Succeed) {
		if (strValue.Compare("N") == 0) {
			return true; //表示安装模式
		}else{
			return false;
		}
	}
	else {
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("isTerminalInstall")("isTerminalInstall get TerminalStage is error , default return fasle");
		return false;//默认认为在升级状态
	}
}

void CUpgradeTaskFSM::upgradeSuccStateBroadCast() {
	UpgradeStateEvent stateEvent;
	stateEvent.strPackName = m_currentTask.pack_name.GetData();
	stateEvent.strExecID = m_currentTask.upgradeTaskId.GetData();
	stateEvent.cInstallState = 'A';//表示成功状态
	stateEvent.bSysInstall = false;
	stateEvent.bLightPack = false;
	stateEvent.strNewVersion = m_currentTask.NewVersion;
	SpSendBroadcast(m_pEntity->GetFunction(), eMsg_UpgradeStateEvent, eMsgSig_UpgradeStateEvent, stateEvent);
}
#ifdef RVC_OS_WIN
#else
int CUpgradeTaskFSM::changeFileAtt(const char* path)
{
	struct stat attr_of_del;
	if (lstat(path, &attr_of_del) == 0)
	{
		//修改为775属性
		mode_t f_attrib = S_IRUSR | S_IWUSR | S_IXUSR | S_IRGRP | S_IWGRP | S_IXGRP | S_IROTH | S_IXOTH;
		if (chmod(path, f_attrib) != 0)
		{
			Dbg("set file attribute is fail,errno=%d, file=%s", errno, path);
			return -1;
		}
		return 0;
	}
	else {
		Dbg("get file attribute is fail,errno=%d, file=%s", errno, path);
		return -1;
	}
}
#endif

void CUpgradeTaskFSM::OnStateTrans(int iSrcState, int iDstState)
{
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("OnStateTrans")("trans from %s to %s", GetStateName(iSrcState), GetStateName(iDstState));
	if (iSrcState >= s4 &&  iDstState <= s3)
	{
		// 发送状态广播(通知业务界面清除状态)
		UpgradeStateEvent stateEvent;
		stateEvent.strPackName = "";
		stateEvent.strExecID = "";
		stateEvent.cInstallState = 'N';
		stateEvent.bSysInstall = false;
		stateEvent.bLightPack = false;
		stateEvent.strNewVersion = "";
		SpSendBroadcast(m_pEntity->GetFunction(), eMsg_UpgradeStateEvent, eMsgSig_UpgradeStateEvent, stateEvent);
	}
	else if (iDstState >= s4)
	{
		//assert(HasRunningUpdate());
		//SetRunConfigStrValue("Install", "Pack", m_strIntallingPack);

		//if (iDstState == s3)
		//	SetRunConfigStrValue("Install", "PendingState", "U");
		//else if (iDstState == s4)
		//	SetRunConfigStrValue("Install", "PendingState", "I");
		//else if (iDstState == s5)
		//	SetRunConfigStrValue("Install", "PendingState", "C");
		//else if (iDstState == s6)
		//	SetRunConfigStrValue("Install", "PendingState", "S");

		// 发送状态广播
		UpgradeStateEvent stateEvent;
		stateEvent.strPackName = m_currentTask.pack_name.GetData();
		stateEvent.strExecID = m_currentTask.upgradeTaskId.GetData();
		stateEvent.cInstallState = GetInstallState(iDstState);
		stateEvent.bSysInstall = false;
		stateEvent.bLightPack = false;
		stateEvent.strNewVersion = m_currentTask.NewVersion;
		SpSendBroadcast(m_pEntity->GetFunction(), eMsg_UpgradeStateEvent, eMsgSig_UpgradeStateEvent, stateEvent);
	}
}

void CUpgradeTaskFSM::OnSysVarEvent(const char *pszKey, const char *pszValue,const char *pszOldValue,const char *pszEntityName)
{
	//监听系统变量状态
	if(strcmp("CallState",pszKey)==0){
		if (pszValue[0] == 'O') {
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("OnSysVarEvent")("m_bDownloadIdle is false ");
			m_bDownloadIdle = false;//可以下载
		} else {
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("OnSysVarEvent")("m_bDownloadIdle is true");
			m_bDownloadIdle = true;//不能下载
		}
	}
}

ErrorCodeEnum CUpgradeTaskFSM::OnInit()
{
	//初始化
	ErrorCodeEnum rc = LoadPersistTaskInfo();//加载运行时文件
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("OnInit")("LoadPersistTaskInfo fail");
		return rc;
	}
	rc = loadCenterCfgInfo();//加载集中配置文件
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("OnInit")("loadCenterCfgInfo fail");
		return rc;
	}
	//加载终端启动的版本号
	CSystemStaticInfo info;
	rc = m_pEntity->GetFunction()->GetSystemStaticInfo(info);
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("OnInit")("load GetSystemStaticInfo fail ");
		return rc;
	}else{
		m_currentVersion = info.InstallVersion;//当前版本号赋值
	}
	//注册callstate变量监控
	rc = m_pEntity->GetFunction()->RegistSysVarEvent("CallState", this);

	if(rc!=Error_Succeed){
		LogWarn(Severity_Middle, rc, ERR_WRAN_REGIST_SYS_VAR_FAIL, CSimpleStringA::Format("RegistSysVarEvent CallState  is fail,%d",(int)rc).GetData());
		return rc;//自检失败
	}else{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("OnInit")("RegistSysVarEvent UIState succ");
	}

	AddStateHooker(this);
	((CUpgradeMgrEntity*)m_pEntity)->testActive();//添加测试active文件是否被占用的方法

	return Error_Succeed;
}

ErrorCodeEnum CUpgradeTaskFSM::OnExit()
{
	m_pEntity->GetFunction()->UnregistSysVarEvent("CallState");
	RemoveStateHooker(this);
	return Error_Succeed;
}

void CUpgradeTaskFSM::s1_on_entry()
{
	//判断是否进入了首页
	CSimpleStringA strValue;

	if(isWork()&&((CUpgradeMgrEntity*)m_pEntity)->m_initSucc){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("====upgrade is start up ====");
		ScheduleTimer(2,10*1000);//首次进入等待hash时间
	}else{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("last upgrade progress is not end or is not initSucc,wait 10s ");
		ScheduleTimer(1, 10*1000);//等待一段时间再判断是否进入首页
	}
}

void CUpgradeTaskFSM::s1_on_exit()
{
	CancelTimer(1);//等待进入首页计时器
	CancelTimer(2);//等待hash计算计时器
}

unsigned int CUpgradeTaskFSM::s1_on_event(FSMEvent* event)
{
	if (event->iEvt == EVT_TIMER)
	{
		if(event->param1 == 1){
			CSimpleStringA strValue;

			if(isWork()&&((CUpgradeMgrEntity*)m_pEntity)->m_initSucc){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("====upgrade is start up ====");
				ScheduleTimer(2,10*1000);//首次进入等待hash时间
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("last upgrade progress is not end or is not initSucc,wait 10s ");
				ScheduleTimer(1, 10*1000);//等待一段时间再判断是否进入首页
			}

		}else if(event->param1 ==2){
			
			PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartDealTask));//进入s2

		}
	}
	return 0;
}

void CUpgradeTaskFSM::s2_on_entry()
{
	//判断是否存在残留任务
	if(m_currentTask.upgradeTaskId.IsNullOrEmpty()&&m_currentTask.cPendingState.IsNullOrEmpty()){
		//直接进入查询新任务
		PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartPoll));//进入S3
	}else{
		//处理上个任务
		PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_DealCurrTask));
	}
}

void CUpgradeTaskFSM::s2_on_exit()
{
	CancelTimer(1);//更新任务状态计时器
	CancelTimer(2);//查询当前任务计时器
}

unsigned int CUpgradeTaskFSM::s2_on_event(FSMEvent* event)
{
	if (event->iEvt == EVT_TIMER){

		if(event->param1 == 1){

			Task::UpdateTaskStatus* uTask = new Task::UpdateTaskStatus(this);
			ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(uTask);
			if(Error_Succeed!=rc){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s2 create UpdateTaskStatus is fail,%d",(int)rc);
				ScheduleTimer(1,60*1000);//继续更新任务状态
			}

		}else if(event->param1 == 2){

			Task::QueryCurrTask* qTask = new Task::QueryCurrTask(this);
			ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(qTask);
			if(Error_Succeed!=rc){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s2 create QueryCurrTask is fail,%d",(int)rc);
				ScheduleTimer(2,4*60*1000);//继续查询当前任务
			}

		}
	}else if (event->iEvt == Event_DealCurrTask)
	{
		//处理运行时文件异常记录的情况
		if(m_currentTask.upgradeTaskId.IsNullOrEmpty()||m_currentTask.createTaskVersion.IsNullOrEmpty()
			||m_currentTask.cPendingState.IsNullOrEmpty()||m_currentTask.pack_name.IsNullOrEmpty()){
			//有任务时，则4个字段不能为空，否则任务有问题
			CSimpleStringA errStr = CSimpleStringA::Format("current Task param is null, clear this task, upgradeTaskId=[%s],createTaskVersion=[%s],cPendingState=[%s],PackName=[%s]",
				m_currentTask.upgradeTaskId.GetData(),m_currentTask.createTaskVersion.GetData(),m_currentTask.cPendingState.GetData(),m_currentTask.pack_name.GetData());
			LogWarn(Severity_Middle, Error_Exception, ERR_TASK_INVALID_RUNINFO_TASK,errStr.GetData());

			if(ClearCurrTaskInfo()){
				PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartPoll));//进入S3
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("clear current task is fail 1,retry int 5's");
				Sleep(5 * 1000);//等待五秒，继续清理
				PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_DealCurrTask));//继续处理上个任务
			}

		}else{
			//任务已到最终状态
			if(m_currentTask.cPendingState=="T"||m_currentTask.cPendingState=="C"||m_currentTask.cPendingState=="X"){
				//取消任务C和切换任务T时，更新任务状态
				Task::UpdateTaskStatus* uTask = new Task::UpdateTaskStatus(this);
				ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(uTask);
				if(Error_Succeed!=rc){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s2 create UpdateTaskStatus is fail,%d",(int)rc);
					ScheduleTimer(1,60*1000);//继续更新任务状态
				}
			}else{
			//当前任务
				if(m_currentTask.createTaskVersion!=m_currentVersion.ToString()){
					//比较遗留任务的创建版本号是否和现在版本一致，不一致，则可能出现拷贝别的终端文件或者已经手工改了别的版本引发，这种情况下自动清理此次任务。
					CSimpleStringA errStr = CSimpleStringA::Format("current Task createTaskVersion[%s] is not equal to currentVersion[%s],clear this task",m_currentTask.createTaskVersion.GetData(),m_currentVersion.ToString().GetData());
					LogWarn(Severity_Middle, Error_Exception, ERR_TASK_INVALID_RUNINFO_TASK,errStr.GetData());

					if(ClearCurrTaskInfo()){
						PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartPoll));//进入S3
					}else{
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("clear current task is fail 2,retry int 5's");
						Sleep(5 * 1000);//等待五秒，继续清理
						PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_DealCurrTask));//继续处理上个任务
					}
				}else{
					Task::QueryCurrTask* qTask = new Task::QueryCurrTask(this);
					ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(qTask);
					if(Error_Succeed!=rc){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s2 create QueryCurrTask is fail,%d",(int)rc);
						ScheduleTimer(2,4*60*1000);//继续查询当前任务
					}
				}
			}
		}
	}else if(event->iEvt == Event_EndUpdateTask){
		//更新任务状态返回结果
		UpdateTaskStatusEvent* pEvent = (UpdateTaskStatusEvent*)event;

		if(pEvent->isSucc){

			//告警回滚和升级成功
			if(m_currentTask.cPendingState=="T"){
				if(m_currentTask.NewVersion==m_currentVersion.ToString()||m_currentTask.NewVersion==""){
					//安装成功
					struct CTaskProcess up;
					up.strPackName  = m_currentTask.pack_name;//安装包名
					up.installVersion  = m_currentVersion.ToString();//当前的版本
					up.CurrentVersion = m_currentVersion;//当前的版本
					up.cInstallState  = "A";
					up.strInstallComment  = "启动成功";
					SendUpgradeTaskProgress(up);
					upgradeSuccStateBroadCast();//广播告知升级成功
					if(m_currentTask.NewVersion.IsNullOrEmpty()){
						DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_OUTSIDE_SYSTEM_START_ID)("体系外升级启动成功");
					}else{
						DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_VERSION_START_ID)("终端版本升级启动成功");
					}
				}else{
					//回滚
					struct CTaskProcess upRoll;
					upRoll.strPackName  = m_currentTask.pack_name;//安装包名
					upRoll.installVersion  = m_currentTask.NewVersion.GetData();//任务升级后的版本号
					upRoll.CurrentVersion = m_currentVersion;//当前的版本
					upRoll.cInstallState  = "R";
					upRoll.strInstallComment  = "自动倒回";
					SendUpgradeTaskProgress(upRoll);
					if(m_currentTask.NewVersion.IsNullOrEmpty()){
						DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(UpgradeMgr_OUTSIDE_SYSTEM_START_ID).setResultCode("RTA5632")("升级启动失败，回滚上一个版本");
					}else{
						DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode(UpgradeMgr_VERSION_START_ID).setResultCode("RTA5631")("升级启动失败，回滚上一个版本");
					}
				}
				ErrorCodeEnum rc = SetRunSucceed(m_currentTask.pack_name.GetData());
				if(rc!=Error_Succeed){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("SetRunSucceed is fail: %d",(int)rc);
				}
			}

			//清除运行时文件和内存任务，跳转到S3
			if(ClearCurrTaskInfo()){
				PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartPoll));//进入S3
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("Event_EndUpdateTask clear current task is fail,retry int 5's");
				Sleep(5 * 1000);//等待五秒，继续清理
				PostEventFIFO(new UpdateTaskStatusEvent(true));//继续更新任务状态
			}
		}else{
			ScheduleTimer(1,60*1000);//继续更新任务状态
		}
	}else if(event->iEvt == Event_EndQueryCurrTask){
		//查询当前任务返回结果
		QueryCurrTaskEvent* pEvent = (QueryCurrTaskEvent*)event;

		if(pEvent->isSucc){
			if(pEvent->isTask_valid){
				//根据不同任务状态值，进入不同阶段。U:下载阶段，I:安装阶段，S切换阶段
				if(m_currentTask.cPendingState=="U"){
					return 4;//下载
				}else if(m_currentTask.cPendingState=="I"){
					return 5;//安装
				}else if(m_currentTask.cPendingState=="S"){
					//加入切换标志，用于切换时判断是否是切换进入的流程。
					m_bSwitchFlag = true;
					return 6;//切换
				}else{
					//无效状态
					LogWarn(Severity_Middle, Error_Exception, ERR_TASK_INVALID_STATUS_FAIL,CSimpleStringA::Format("invalid pending state : %s",m_currentTask.cPendingState.GetData()).GetData());
					//任务无效，清理任务
					if(ClearCurrTaskInfo()){
						PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartPoll));//进入S3
					}else{
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("Event_EndQueryCurrTask clear current task is fail 2,retry int 5's");
						Sleep(5 * 1000);//等待五秒，继续清理
						PostEventFIFO(new QueryCurrTaskEvent(true,true));//继续清理当前任务
					}
				}
			}else{
				LogWarn(Severity_Middle, Error_Exception, ERR_TASK_INVALID_RUNINFO_TASK,CSimpleStringA::Format("current task is invalid taskid=%s, begin delete",m_currentTask.upgradeTaskId.GetData()).GetData());
				//任务无效，清理任务
				if(ClearCurrTaskInfo()){
					PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartPoll));//进入S3
				}else{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("Event_EndQueryCurrTask clear current task is fail 1,retry int 5's");
					Sleep(5 * 1000);//等待五秒，继续清理
					PostEventFIFO(new QueryCurrTaskEvent(true,false));//继续清理当前任务
				}
			}
		}else{
			ScheduleTimer(2,4*60*1000);//继续查询当前任务
		}	
	}
	return 0;
}

void CUpgradeTaskFSM::s3_on_entry()
{
	//查询新任务：先预查询任务，传送hash，接着查询任务
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("entery S3");
	m_queryNewTaskCount = 0;
	m_strPreTaskId = "";
	m_bNeedHash=0;
	m_fileSM3List="";
	m_fileSM3ListHash="";
	isSendHash=false;
	//预查询任务
	Task::QueryNewPreTask* qTask = new Task::QueryNewPreTask(this);
	ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(qTask);
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s3 create QueryNewPreTask fail,wait 4 min retry ,err=%d",(int)rc);
		ScheduleTimer(1, 4*60*1000);//等待4分钟后再次查询是否有新任务
	}

}

void CUpgradeTaskFSM::s3_on_exit()
{
	CancelTimer(1);//预查询任务计时器
	CancelTimer(2);//上传hash计时器
	CancelTimer(3);//继续任务计时器
	m_queryNewTaskCount =0;
	m_strPreTaskId = "";
	m_bNeedHash=0;
	m_fileSM3List="";
	m_fileSM3ListHash="";
	isSendHash=false;
}

unsigned int CUpgradeTaskFSM::s3_on_event(FSMEvent* event)
{

	if (event->iEvt == Event_EndPoll)
	{
		QueryNewTaskEvent* pEvent = (QueryNewTaskEvent*)event;

		if(pEvent->isSucc){
			//查询成功,无任务
			if(m_currentTask.upgradeTaskId.IsNullOrEmpty()){
				m_queryNewTaskCount++;
				if(m_queryNewTaskCount>=QUERY_NO_TASK_WARN_LIMIT){
					//10次查询还是无任务，则告警一次
					LogWarn(Severity_Low, Error_Exception, ERR_TASK_QUERY_NO_TASK,"QueryNewTask 5 times succ,no new task");
					m_queryNewTaskCount=0;
				}
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("QueryNewTask succ,no new task, wait 4 min retry");
				ScheduleTimer(1, 4*60*1000);//等待4分钟后再次查询是否有新任务
			}else{
				//写入运行时文件
				bool isWriteOk=false;
				while(true){
					if(SetRunConfigStrValue("upgradeTask","NewVersion","")!=Error_Succeed){
						break;
					}
					if(SetRunConfigStrValue("upgradeTask","PendingState","U")!=Error_Succeed){
						break;
					}
					if(SetRunConfigStrValue("upgradeTask","CreateTaskVersion",m_currentTask.createTaskVersion.GetData())!=Error_Succeed){
						break;
					}
					if(SetRunConfigStrValue("upgradeTask","PackName",m_currentTask.pack_name.GetData())!=Error_Succeed){
						break;
					}
					if(SetRunConfigStrValue("upgradeTask","UpgradeTaskId",m_currentTask.upgradeTaskId.GetData())!=Error_Succeed){
						break;
					}
					isWriteOk=true;
					break;
				}

				if(isWriteOk){		
					//告警下载
					struct CTaskProcess up;
					up.strPackName  = m_currentTask.pack_name;//安装包名
					up.installVersion  = m_currentTask.pack_version;//安装的版本
					up.CurrentVersion = m_currentVersion;//当前的版本
					up.cInstallState  = "D";
					up.strInstallComment  = "正在下载";
					SendUpgradeTaskProgress(up);

					m_currentTask.cPendingState = "U";//改变内存变量为U
					PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartDownload));//进入S4
				}else{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("Event_EndPoll write runinfo is fail,retry int 5's");
					Sleep(5 * 1000);//等待五秒，继续创建
					PostEventFIFO(new QueryNewTaskEvent(true));//继续创建任务

				}			
			}
		}else{
			//查询失败
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("QueryNewTask fail,wait 4 min retry");
			ScheduleTimer(1, 4*60*1000);//等待4分钟后再次查询是否有新任务
		}
	}
	else if(event->iEvt == EVT_TIMER){
		
		if(event->param1 == 1){
			//发起预查询任务
			Task::QueryNewPreTask* nTask = new Task::QueryNewPreTask(this);
			ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(nTask);
			if(rc!=Error_Succeed){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s3 create QueryNewPreTask fail,wait 4 min retry ,err=%d",(int)rc);
				ScheduleTimer(1, 4*60*1000);//等待4分钟后再次查询是否有新任务
			}
		}else if(event->param1 == 2){
			//上传hash
			Task::SendSM3Task* SM3Task = new Task::SendSM3Task(this);
			ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(SM3Task);
			if(rc!=Error_Succeed){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s3 create SendSM3Task fail,err=%d",(int)rc);
				ScheduleTimer(2, 60*1000);//等待1分钟过后再次发送
			}
		}else if(event->param1 == 3){
			//继续任务
			Task::QueryNewContinueTask* nTask = new Task::QueryNewContinueTask(this);
			ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(nTask);
			if(rc!=Error_Succeed){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s3 create QueryNewContinueTask fail,err=%d",(int)rc);
				ScheduleTimer(3, 4*60*1000);//等待4分钟过后再次发送
			}
		}
	}
	else if(event->iEvt == Event_EndPrePoll){
		QueryNewPreTaskEvent* pEvent = (QueryNewPreTaskEvent*)event;
		if(pEvent->isSucc){
			if(m_strPreTaskId.IsNullOrEmpty()){
				m_queryNewTaskCount++;
				if(m_queryNewTaskCount>=QUERY_NO_TASK_WARN_LIMIT){
					LogWarn(Severity_Low, Error_Exception, ERR_TASK_QUERY_NO_TASK,"QueryNewPreTask 15 times succ,no new task");
					m_queryNewTaskCount=0;
				}
				if (isAuthSucc()) {
					ScheduleTimer(1, 4 * 60 * 1000);//等待4分钟后再次查询是否有新任务
				}
				else {
					ScheduleTimer(1, 30 * 1000);//等待30s后再次查询是否有新任务
				}
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("QueryNewPreTask succ, task_id=%s",m_strPreTaskId.GetData());
				if(m_bNeedHash){
					//预查询成功
					if(isSendHash){
						//之前发送hash成功，直接开始继续任务查询线程
						Task::QueryNewContinueTask* nTask = new Task::QueryNewContinueTask(this);
						ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(nTask);
						if(rc!=Error_Succeed){
							DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s3 create QueryNewContinueTask fail,err=%d",(int)rc);
							ScheduleTimer(3, 60*1000);//再次查询是否有新任务
						}		
					}else{
						//之前未发送hash成功，开始计算hash线程
						Task::SendSM3Task* SM3Task = new Task::SendSM3Task(this);
						ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(SM3Task);
						if(rc!=Error_Succeed){
							DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s3 create SendSM3Task fail,err=%d",(int)rc);
							ScheduleTimer(2, 60*1000);//等待一分钟过后再次发送
						}
					}
				}else{
					//不需要hash，直接继续查询新任务
					Task::QueryNewContinueTask* nTask = new Task::QueryNewContinueTask(this);
					ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(nTask);
					if(rc!=Error_Succeed){
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s3 create QueryNewContinueTask fail,err=%d",(int)rc);
						ScheduleTimer(3, 60*1000);//等待4分钟后再次查询是否有新任务
					}
				}
			}
		}else{
			//预查询失败
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("QueryNewPreTask fail,wait 4 min retry");
			if (isAuthSucc()) {
				ScheduleTimer(1, 4 * 60 * 1000);//等待4分钟后再次预查询是否有新任务
			}
			else {
				ScheduleTimer(1, 30 * 1000);//等待30s后再次查询是否有新任务
			}
			
		}


	}
	else if(event->iEvt == Event_EndSendSM3Task){
		Task::QueryNewContinueTask* nTask = new Task::QueryNewContinueTask(this);
		ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(nTask);
		if(rc!=Error_Succeed){
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s3 create QueryNewContinueTask fail,err=%d",(int)rc);
			ScheduleTimer(3, 60*1000);//等待4分钟后再次查询是否有新任务
		}
	}
	else if(event->iEvt == Event_EndContinuePoll){
		QueryNewContinueTaskEvent* pEvent = (QueryNewContinueTaskEvent*)event;
		if(pEvent->retParam == 0){
			//查询失败，继续查询
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("QueryNewContinueTask fail,wait 4 min retry");
			if (isAuthSucc()) {
				ScheduleTimer(3, 4 * 60 * 1000);//等待4分钟后再次查询继续新任务
			}
			else {
				ScheduleTimer(3, 30 * 1000);//等待30s后再次查询继续新任务
			}
		}else if(pEvent->retParam == 1){
			//查询成功，跳到下一个状态，写入运行时文件
			bool isWriteOk=false;
			while(true){
				if(SetRunConfigStrValue("upgradeTask","NewVersion","")!=Error_Succeed){
					break;
				}
				if(SetRunConfigStrValue("upgradeTask","PendingState","U")!=Error_Succeed){
					break;
				}
				if(SetRunConfigStrValue("upgradeTask","CreateTaskVersion",m_currentTask.createTaskVersion.GetData())!=Error_Succeed){
					break;
				}
				if(SetRunConfigStrValue("upgradeTask","PackName",m_currentTask.pack_name.GetData())!=Error_Succeed){
					break;
				}
				if(SetRunConfigStrValue("upgradeTask","UpgradeTaskId",m_currentTask.upgradeTaskId.GetData())!=Error_Succeed){
					break;
				}
				isWriteOk=true;
				break;
			}

			if(isWriteOk){		
				//告警下载
				struct CTaskProcess up;
				up.strPackName  = m_currentTask.pack_name;//安装包名
				up.installVersion  = m_currentTask.pack_version;//安装的版本
				up.CurrentVersion = m_currentVersion;//当前的版本
				up.cInstallState  = "D";
				up.strInstallComment  = "正在下载";
				SendUpgradeTaskProgress(up);

				m_currentTask.cPendingState = "U";//改变内存变量为U
				PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartDownload));//进入S4
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("Event_EndPoll write runinfo is fail,retry int 5's");
				Sleep(5 * 1000);//等待五秒，继续创建
				PostEventFIFO(new QueryNewContinueTaskEvent(1));//继续创建任务
			}			
		}else{
			//跳出，重新预检查任务
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("QueryNewContinueTask fail,jump to PreTask");
			if (isAuthSucc()) {
				ScheduleTimer(1, 4 * 60 * 1000);//等待4分钟后再次预查询是否有新任务
			}
			else {
				ScheduleTimer(1, 30 * 1000);//等待30s后再次预查询是否有新任务
			}
		}
	}
	return 0;
}

void CUpgradeTaskFSM::s4_on_entry()
{
	//下载升级包
	m_bTaskCancel = false;//默认任务非取消
	if(m_bDownloadIdle){
		PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_Download_Idle));//进入不可下载状态
	}else{
		Task::DownloadPackTask* dTask = new Task::DownloadPackTask(this);
		ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(dTask);
		if(rc!=Error_Succeed){
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s4 create DownloadPackTask fail,err=%d",(int)rc);
			ScheduleTimer(1, 15*1000);//等待15秒再试
		}
	}
	ScheduleTimer(2, 30*1000);//启动查询任务是否有效
}

void CUpgradeTaskFSM::s4_on_exit()
{
	CancelTimer(1);//正常下载计时器
	CancelTimer(2);//查询任务是否取消计时器
	CancelTimer(3);//外部状态中止下载计时器
}

unsigned int CUpgradeTaskFSM::s4_on_event(FSMEvent* event)
{
	
	if (event->iEvt == EVT_TIMER)
	{
		if(event->param1 == 1){
			Task::DownloadPackTask* dTask = new Task::DownloadPackTask(this);
			ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(dTask);
			if(rc!=Error_Succeed){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s4 create DownloadPackTask fail,err=%d",(int)rc);
				ScheduleTimer(1, 15*1000);//再次下载升级包
			}

		}else if(event->param1 == 2){

			Task::QueryTaskStatus* dTask = new Task::QueryTaskStatus(this);
			ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(dTask);
			if(rc!=Error_Succeed){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s4 create QueryTaskStatus fail,err=%d",(int)rc);
				ScheduleTimer(2, 30*1000);//再次查询任务是否有效
			}

		}else if(event->param1 == 3){
			//无效状态
			if(m_bDownloadIdle){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("upgradeTask download entry idle 10s");
				ScheduleTimer(3,10*1000);//等待下次是否空闲		
			}else{
				Task::DownloadPackTask* dTask = new Task::DownloadPackTask(this);
				ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(dTask);
				if(rc!=Error_Succeed){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s4 create DownloadPackTask fail,err=%d",(int)rc);
					ScheduleTimer(3, 10*1000);//等待下次是否空闲
				}
			}
		}
	}else if (event->iEvt == Event_EndQueryTaskStatus){

		QueryTaskStatusEvent* pEvent = (QueryTaskStatusEvent*)event;

		if(pEvent->isSucc){
			if(pEvent->isTask_valid){		
				ScheduleTimer(2, 30*1000);//有效，再次查询任务是否有效
				m_bTaskCancel = false;
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("query upgradeTask is cancel,set m_bTaskCancel=true");
				m_bTaskCancel = true;//取消下载，结束查询任务是否有效计时器
			}
		}else{
			ScheduleTimer(2, 30*1000);//通讯失败，再次查询任务是否有效
		}

	}else if (event->iEvt == Event_EndDownload){

		DownloadPackTaskEvent* pEvent = (DownloadPackTaskEvent*)event;
		if(pEvent->isSucc){

			if(SetRunConfigStrValue("upgradeTask","PendingState","I")==Error_Succeed){
				//下载成功
				m_currentTask.cPendingState = "I";//改变内存变量为I
				if(m_currentTask.pack_version.IsNullOrEmpty()){
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_OUTSIDE_SYSTEM_DOWNLOAD_ID)("体系外下载成功");
				}else{
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_VERSION_DOWNLOAD_ID)("终端版本下载成功");
				}
				PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartInstall));//进入S5
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("Event_EndDownload write runinfo is fail,retry in 5's");
				Sleep(5 * 1000);//等待五秒
				PostEventFIFO(new DownloadPackTaskEvent(true));//继续写运行时文件
			}
		
		}else{
			if (m_currentTask.pack_version.IsNullOrEmpty()) {
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_OUTSIDE_SYSTEM_DOWNLOAD_ID).setResultCode("RTA5634")("体系外下载失败,通讯报错");
			}
			else {
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_VERSION_DOWNLOAD_ID).setResultCode("RTA5633")("终端版本下载失败,通讯报错");
			}
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("download pack is fail , wait for 2 min retry download");
			ScheduleTimer(1, 120*1000);//下载失败,等2分钟,再次下载任务
		}
		
	}else if (event->iEvt == Event_Download_Fail){

		DownloadPackTaskFailEvent* pEvent = (DownloadPackTaskFailEvent*)event;
		//写入运行时文件，状态为C
		if(SetRunConfigStrValue("upgradeTask","PendingState","C")==Error_Succeed){
					
			//告警下载失败
			struct CTaskProcess up;
			up.strPackName  = m_currentTask.pack_name;//安装包名
			up.installVersion  = m_currentTask.pack_version;//安装的版本
			up.CurrentVersion = m_currentVersion;//当前的版本
			up.cInstallState  = "C";
			up.strInstallComment  = pEvent->errMsg.c_str();
			SendUpgradeTaskProgress(up);

			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("upgradeTask download is fail ,prepare to s2");
			m_currentTask.cPendingState = "C";//改变内存变量C

			if (m_currentTask.pack_version.IsNullOrEmpty()) {
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_OUTSIDE_SYSTEM_DOWNLOAD_ID).setResultCode("RTA5636")("体系外下载失败:%s", pEvent->errMsg.c_str());
			}
			else {
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_VERSION_DOWNLOAD_ID).setResultCode("RTA5635")("终端版本下载失败:%s", pEvent->errMsg.c_str());
			}

			PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartDealTask));//进入S2
		}else{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("Event_Download_Fail write runinfo is fail,retry in 5's");
			Sleep(5 * 1000);//等待五秒
			PostEventFIFO(new DownloadPackTaskFailEvent(pEvent->errMsg));//继续写运行时文件
		}

	}else if (event->iEvt == Event_Download_Idle){

		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("upgradeTask download entry idle 10s");
		ScheduleTimer(3,10*1000);//等待下次是否空闲

	}else if (event->iEvt == Event_CancelTask){

		//取消任务,清理任务
		if(ClearCurrTaskInfo()){
			//告警下载取消
			struct CTaskProcess up;
			up.strPackName  = m_currentTask.pack_name;//安装包名
			up.installVersion  = m_currentTask.pack_version;//安装的版本
			up.CurrentVersion = m_currentVersion;//当前的版本
			up.cInstallState  = "C";
			up.strInstallComment  = "升级任务策略已取消";
			SendUpgradeTaskProgress(up);
			
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("upgradeTask is cancel,prepare to s3");
			PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartPoll));//进入S3
		}else{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("clear current task is fail 1,retry in 5's");
			Sleep(5 * 1000);//等待五秒，继续清理
			PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_CancelTask));//继续取消任务
		}
	}
	return 0;
}

void CUpgradeTaskFSM::s5_on_entry()
{
	//停止播放广告和音频
	Task::StopMediaPlayTask* nTask = new Task::StopMediaPlayTask(this);
	ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(nTask);
	if(rc!=Error_Succeed){
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s5 create StopMediaPlayTask fail,err=%d",(int)rc);
		ScheduleTimer(1, 30*1000);//等待30秒再试
	}
}

void CUpgradeTaskFSM::s5_on_exit()
{	
	CancelTimer(1);//停止广播和声音计时器
	CancelTimer(2);//解压计时器
	CancelTimer(3);//安装计时器
	CancelTimer(4);//等待跳转切换计时器
}

unsigned int CUpgradeTaskFSM::s5_on_event(FSMEvent* event)
{
	if(event->iEvt == EVT_TIMER){

		if(event->param1 == 1){
			//再次发起任务查询
			Task::StopMediaPlayTask* nTask = new Task::StopMediaPlayTask(this);
			ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(nTask);
			if(rc!=Error_Succeed){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s5 create StopMediaPlayTask fail,err=%d",(int)rc);
				ScheduleTimer(1, 30*1000);//等待30秒再停止播放广告和音频
			}
		}else if(event->param1 == 2){
			Task::UnzipPackTask* iTask = new Task::UnzipPackTask(this);
			ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(iTask);
			if(rc!=Error_Succeed){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s5 create UnzipPackTask fail,err=%d",(int)rc);
				ScheduleTimer(2, 30*1000);//等待30秒再解压包
			}
		}else if(event->param1 == 3){
			BOOL doInstall = true;
			if(!m_startFlag) //非强制安装
			{
				if (m_currentTask.pack_version.GetLength() == 0) //体系外升级
				{
					CSimpleStringA strState;
					ErrorCodeEnum err = m_pEntity->GetFunction()->GetSysVar("UIState", strState);
					if (/*TRUE ||*/ err == Error_Succeed && strState != CSimpleStringA("M")) //非主界面不安装
					{
						doInstall = false;
					}
				}
			}
			//对于终端初始化安装时，直接通过。
			if (isTerminalInstall()) {
				doInstall = true;
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("s5 create InstallPackTask terminal new install");
			}

			if (doInstall)
			{
				Task::InstallPackTask* iTask = new Task::InstallPackTask(this);
				ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(iTask);
				if (rc != Error_Succeed) {
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("s5 create InstallPackTask fail,err=%d", (int)rc);
					ScheduleTimer(3, 30 * 1000);//等待30秒再安装
				}
			}
			else {
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("s5 UIState is not M , create InstallPackTask wait for the next time");
				ScheduleTimer(3, 30 * 1000);//等待30秒再安装
			}

		}
		else if (event->param1 == 4) {
			//已安装成功，直接进入切换状态
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("s5 create InstallPackTask succ, enter into S6");
			PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartSwitch));//进入S6
		}
	}else if(event->iEvt == Event_EndStopMediaPlayTask){

		StopMediaPlayTaskEvent* pEvent = (StopMediaPlayTaskEvent*)event;
		if(pEvent->isSucc){
			//开始解压
			Task::UnzipPackTask* iTask = new Task::UnzipPackTask(this);
			ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(iTask);
			if(rc!=Error_Succeed){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s5 create UnzipPackTask fail,err=%d",(int)rc);
				ScheduleTimer(2, 30*1000);//等待30秒再解压包
			}
		}else{
			ScheduleTimer(1, 30*1000);//等待30秒再停止播放广告和音频
		}

	}else if (event->iEvt == Event_EndUnzipPackTask){

		UnzipPackTaskEvent* pEvent = (UnzipPackTaskEvent*)event;
		if(pEvent->isSucc){
			//开始安装 
			BOOL doInstall = true;
			if (!m_startFlag) //非强制安装
			{
				if (m_currentTask.pack_version.GetLength() == 0) //体系外升级
				{
					CSimpleStringA strState;
					ErrorCodeEnum err = m_pEntity->GetFunction()->GetSysVar("UIState", strState);
					if (/*TRUE ||*/ err == Error_Succeed && strState != CSimpleStringA("M")) //非主界面不安装
					{
						doInstall = false;
					}
				}
			}
			//对于终端初始化安装时，直接通过。
			if (isTerminalInstall()) {
				doInstall = true;
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("s5 create InstallPackTask terminal new install");
			}

			if (doInstall)
			{
				Task::InstallPackTask* iTask = new Task::InstallPackTask(this);
				ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(iTask);
				if (rc != Error_Succeed) {
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("s5 create InstallPackTask fail,err=%d", (int)rc);
					ScheduleTimer(3, 30 * 1000);//等待30秒再安装
				}

			}
			else{
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("s5 UIState is not M , create InstallPackTask wait for the next time");
				ScheduleTimer(3, 30 * 1000);//等待30秒再安装
			}

		}else{
			if(m_currentTask.stop_media_play){
				//恢复广告和音频播放
				ErrorCodeEnum rc = m_pEntity->GetFunction()->SetSysVar("UpdateState", "0", true);
				if(Error_Succeed != rc){
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("unzip fail set UpdateState to 0 fail, err=%d",(int)rc);
				}
			}

			//解压失败,写入运行时文件，状态为C
			if(SetRunConfigStrValue("upgradeTask","PendingState","C")==Error_Succeed){
			
				//告警下载取消
				struct CTaskProcess up;
				up.strPackName  = m_currentTask.pack_name;//安装包名
				up.installVersion  = m_currentTask.pack_version;//安装的版本
				up.CurrentVersion = m_currentVersion;//当前的版本
				up.cInstallState  = "C";
				up.strInstallComment  = "解压失败";
				SendUpgradeTaskProgress(up);

				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("unzip pack is fail ,prepare to s2");
				m_currentTask.cPendingState = "C";//改变内存变量C
				PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartDealTask));//进入S2
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("Event_EndUnzipPackTask write runinfo is fail,retry int 5's");
				Sleep(5 * 1000);//等待五秒
				PostEventFIFO(new UnzipPackTaskEvent(false));//继续写运行时文件
			}
			
		}

	}else if (event->iEvt == Event_EndInstallPackTask){

		if(m_currentTask.stop_media_play){
			//恢复广告和音频播放
			ErrorCodeEnum rc = m_pEntity->GetFunction()->SetSysVar("UpdateState", "0", true);
			if(Error_Succeed != rc){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("EndInstallPackTask set UpdateState to 0 fail, err=%d",(int)rc);
			}
		}

		InstallPackTaskEvent* pEvent = (InstallPackTaskEvent*)event;

		if(pEvent->isSucc){
			//安装成功进入切换,设置状态为S和新版本号
			//写入运行时文件
			bool isWriteOk=false;
			while(true){
				if(SetRunConfigStrValue("upgradeTask","NewVersion",m_currentTask.NewVersion.GetData())!=Error_Succeed){
					break;
				}
				if(SetRunConfigStrValue("upgradeTask","PendingState","S")!=Error_Succeed){
					break;
				}
				isWriteOk=true;
				break;
			}

			if(isWriteOk){
				//告警安装
				struct CTaskProcess up;
				up.strPackName  = m_currentTask.pack_name;//安装包名
				if(m_currentTask.NewVersion.IsNullOrEmpty()){
					up.installVersion  = m_currentVersion.ToString();//当前版本号
				}else{
					up.installVersion  = m_currentTask.NewVersion;//任务升级后的版本号
				}
				up.CurrentVersion = m_currentVersion;//当前的版本
				up.cInstallState  = "W";
				up.strInstallComment  = "安装成功";
				SendUpgradeTaskProgress(up);

				m_currentTask.cPendingState = "S";//改变内存变量S
				if(m_currentTask.pack_version.IsNullOrEmpty()){
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_OUTSIDE_SYSTEM_INSTALL_ID)("体系外安装成功");
				}else{
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_VERSION_INSTALL_ID)("终端版本安装成功");
				}
				//modify by lwt 修改为非兜底升级时等待一段时间再进入切换状态。
				if (m_startFlag) {
					PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartSwitch));//进入S6
				}
				else {
					ScheduleTimer(4, 20 * 1000);//等待20秒再进入切换状态
				}

	
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("Event_EndInstallPackTask write runinfo is fail,retry int 5's");
				Sleep(5 * 1000);//等待五秒
				PostEventFIFO(new InstallPackTaskEvent(true,"",0));//继续写运行时文件
			}	

		}else{
			if(pEvent->failStatus==0){
				//安装失败，设置状态为C
				if(SetRunConfigStrValue("upgradeTask","PendingState","C")==Error_Succeed){

					
					//告警下载取消
					struct CTaskProcess up;
					up.strPackName  = m_currentTask.pack_name;//安装包名
					up.installVersion  = m_currentTask.pack_version;//安装的版本
					up.CurrentVersion = m_currentVersion;//当前的版本
					up.cInstallState  = "C";
					up.strInstallComment  = pEvent->errMsg;//错误信息
					SendUpgradeTaskProgress(up);

					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("install pack is fail ,prepare to s2");
					m_currentTask.cPendingState = "C";//改变内存变量C

					if (m_currentTask.pack_version.IsNullOrEmpty()) {
						DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_OUTSIDE_SYSTEM_INSTALL_ID).setResultCode("RTA5638")("体系外安装失败");
					}else{
						DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_VERSION_INSTALL_ID).setResultCode("RTA5637")("终端版本安装失败");
					}

					PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartDealTask));//进入S2
				}else{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("Event_EndInstallPackTask write runinfo is fail,retry int 5's");
					Sleep(5 * 1000);//等待五秒
					PostEventFIFO(new InstallPackTaskEvent(false,pEvent->errMsg,0));//继续写运行时文件
				}
			}else if(pEvent->failStatus==-1){
				//安装失败，设置状态为X 未知
				if(SetRunConfigStrValue("upgradeTask","PendingState","X")==Error_Succeed){

					
					//告警下载取消
					struct CTaskProcess up;
					up.strPackName  = m_currentTask.pack_name;//安装包名
					up.installVersion  = m_currentTask.pack_version;//安装的版本
					up.CurrentVersion = m_currentVersion;//当前的版本
					up.cInstallState  = "X";
					up.strInstallComment  = pEvent->errMsg;//错误信息
					SendUpgradeTaskProgress(up);

					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("install pack is fail ,prepare to s2");
					m_currentTask.cPendingState = "X";//改变内存变量X
					PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartDealTask));//进入S2
				}else{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("Event_EndInstallPackTask write runinfo is fail,retry int 5's");
					Sleep(5 * 1000);//等待五秒
					PostEventFIFO(new InstallPackTaskEvent(false,pEvent->errMsg,-1));//继续写运行时文件
				}
			}
		}

	}
	return 0;
}

void CUpgradeTaskFSM::s6_on_entry()
{
	//进入切换处理流程:不同类型包判断不同
	//时间长，需要判断后台是否取消任务
	if (CheckIfCanSwitchNow())
	{
		ScheduleTimer(2,1000);//进行版本切换操作
	}else{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("not applicable time to switch, retry in 20's");
		ScheduleTimer(1, 20*1000);//继续等待
	}
	ScheduleTimer(3, 30*1000);//启动查询任务是否有效
}

void CUpgradeTaskFSM::s6_on_exit()
{
	CancelTimer(1);//判断是否切换时间计时器
	CancelTimer(2);//切换运行时文件写入计时器
	CancelTimer(3);//任务取消计时器
	CancelTimer(4);//切换重启写入active文件计时器
	CancelTimer(5);//active文件写入失败写运行时计时器
	m_bSwitchFlag = false;//切换标志重置。
}

unsigned int CUpgradeTaskFSM::s6_on_event(FSMEvent* event)
{
	if (event->iEvt == EVT_TIMER)
	{
		if(event->param1==1)
		{
			//进入切换处理流程:不同类型包判断不同
			if (CheckIfCanSwitchNow())
			{
				ScheduleTimer(2,1000);//进行版本切换操作
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("not applicable time to switch, retry in 20's");
				ScheduleTimer(1, 20*1000);//继续等待切换时机
			}

		}else if(event->param1==2){
			
			//修改运行时文件状态T
			if(SetRunConfigStrValue("upgradeTask","PendingState","T")==Error_Succeed){
		
				//告警切换
				struct CTaskProcess up;
				up.strPackName  = m_currentTask.pack_name;//安装包名
				if(m_currentTask.NewVersion.IsNullOrEmpty()){
					up.installVersion  = m_currentVersion.ToString();//当前版本号
				}else{
					up.installVersion  = m_currentTask.NewVersion;//任务升级后的版本号
				}
				up.CurrentVersion = m_currentVersion;//当前的版本
				up.cInstallState  = "S";
				up.strInstallComment  = "已设为启动版本";
				SendUpgradeTaskProgress(up);

				m_currentTask.cPendingState = "T";//改变内存变量
				if(m_currentTask.pack_version.IsNullOrEmpty()){
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_OUTSIDE_SYSTEM_SWTICH_ID)("体系外切换成功");
				}else{
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode(UpgradeMgr_VERSION_SWTICH_ID)("终端版本切换成功");
				}
				ScheduleTimer(4,5*1000);//等待告警上报，准备修改active文件，进行切换
				
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("switch write runinfo is fail,retry in 10's");
				ScheduleTimer(1, 10*1000);//继续等待下次切换机会再重试
			}

			

		}else if(event->param1==3){

			Task::QueryTaskStatus* dTask = new Task::QueryTaskStatus(this);
			ErrorCodeEnum rc = m_pEntity->GetFunction()->PostThreadPoolTask(dTask);
			if(rc!=Error_Succeed){
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s6 create QueryTaskStatus fail,err=%d",(int)rc);
				ScheduleTimer(3, 30*1000);//再次查询任务是否有效
			}

		}else if(event->param1==4){

			//修改active文件
			if(UpgradeToNewVersion()==Error_Succeed){

				SwitchUpgradeNow();//切换版本

			}else{

				ScheduleTimer(5,3*1000);//UpgradeToNewVersion执行失败后写运行时计时器
			}

		}else if(event->param1==5){
			
			if(SetRunConfigStrValue("upgradeTask","PendingState","C")==Error_Succeed){
				//告警切换失败
				struct CTaskProcess up;
				up.strPackName  = m_currentTask.pack_name;//安装包名
				if(m_currentTask.NewVersion.IsNullOrEmpty()){
					up.installVersion  = m_currentVersion.ToString();//当前版本号
				}else{
					up.installVersion  = m_currentTask.NewVersion;//任务升级后的版本号
				}
				up.CurrentVersion = m_currentVersion;//当前的版本
				up.cInstallState  = "C";
				up.strInstallComment  = "更新active文件失败";//错误信息
				SendUpgradeTaskProgress(up);

				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("UpgradeToNewVersion is fail ,prepare to s2");
				m_currentTask.cPendingState = "C";//改变内存变量C

				PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartDealTask));//进入S2
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("UpgradeToNewVersion fail, write runinfo is fail，retry in 10's");
				ScheduleTimer(5,10*1000);//继续重试写入运行时
			}

		}
	}else if (event->iEvt == Event_EndQueryTaskStatus){		
		QueryTaskStatusEvent* pEvent = (QueryTaskStatusEvent*)event;
		if(pEvent->isSucc){
			if(pEvent->isTask_valid){		
				ScheduleTimer(3, 30*1000);//有效，再次查询任务是否有效
			}else{
				//无效，清理任务
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("query upgradeTask is cancel");
				if(ClearCurrTaskInfo()){
					//告警下载取消
					struct CTaskProcess up;
					up.strPackName  = m_currentTask.pack_name;//安装包名
					up.installVersion  = m_currentTask.pack_version;//安装的版本
					up.CurrentVersion = m_currentVersion;//当前的版本
					up.cInstallState  = "C";
					up.strInstallComment  = "升级任务策略已取消";
					SendUpgradeTaskProgress(up);

					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("upgradeTask is cancel,prepare to s3");
					PostEventFIFO(new FSMEvent(CUpgradeTaskFSM::Event_StartPoll));//进入S3
				}else{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("clear current task is fail 1,retry in 5's");
					Sleep(5 * 1000);//等待五秒，继续清理
					PostEventFIFO(new QueryTaskStatusEvent(true,false));//继续取消任务
				}
			}
		}else{
			ScheduleTimer(3, 30*1000);//通讯失败，再次查询任务是否有效
		}
	}
	
	return 0;
}

void CUpgradeTaskFSM::s7_on_entry()
{
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("enter disable state , wait framework restart or OS restart");
}

void CUpgradeTaskFSM::s7_on_exit()
{

}

unsigned int CUpgradeTaskFSM::s7_on_event(FSMEvent* event)
{
	return 0;
}