ISCS需求及问题

// Gena_Notify.cpp: implementation of the Gena_Notify class.

//

//////////////////////////////////////////////////////////////////////

//#include "stdafx.h"

#include "Gena_Notify_s.h"

#ifdef _DEBUG

#undef THIS_FILE

static char THIS_FILE[]=__FILE__;

#define new DEBUG_NEW

#endif

#define MaxPacket	50

//////////////////////////////////////////////////////////////////////

// Construction/Destruction

//////////////////////////////////////////////////////////////////////

Gena_Notify::~Gena_Notify()

{

}

void   Gena_Notify::Init( S_PROTOCOLCFG * pcfg )

{

	PRawCtrl	=	pcfg->PRawCtrl;

	pRxBuf		=	pcfg->pRxBuf;

	pTxBuf		=	pcfg->pTxBuf;

	pCmdMem		=	pcfg->pCmdMem;

	pRtu		=	pcfg->pRtu;

	pLink		=	pcfg->pLink;

	pTable		=	pcfg->pTable;

	pZfDataCtrl	=	pcfg->pZfDataCtrl;

//	pHis		=	pcfg->pHis;

	pVst		=	pcfg->pVst;

	pPara		=   pcfg->pPara;

	m_sendFireSubResqFlag = 0;

	m_sendVentSubResqFlag = 0;

	m_sendPowerSubResqFlag = 0;

	m_responseFlag = 0;

	m_rollingFlag = 0;

	m_ventStepFlag=1;

	m_StepFlag = 1;

//	m_lastSubTime = GetNowSecond();

	m_LastSendTime = GetNowSecond();

//WYF 20181228

	char filename[512];

	CReadConf readconf;

	char *pWorkPath;	

	pWorkPath=getenv("FEPROOT");

	if(pWorkPath!=NULL){

#if defined(__unix)

    sprintf(filename,"%s%s",pWorkPath,"/cfg/AtsDef.ini");

#else

    sprintf(filename,"%s%s",pWorkPath,"\\cfg\\AtsDef.ini");

#endif

	}

	StaNum=0;

	StaNum=readconf.ReadLong("HEADCODE","count",filename,"1");

	if(40<StaNum)StaNum=40;

	if(0<StaNum)StaNum-=1;

	readconf.ReadString("ATSSUBObj","EMCS",bEMCS,filename,"YES");

	readconf.ReadString("ATSSUBObj","PSCDAA",bPSCADA,filename,"YES");

	readconf.ReadString("ATSSUBObj","FAS",bFAS,filename,"NO");

	m_RxTimeout=pLink->GetRxTimeouts();//WYF 20190118 ȫ????ɨ??????

	if(m_RxTimeout<10)m_RxTimeout=30;

	m_CallAlldata=0;

}

sint32 Gena_Notify::TxProc()

{

	E_RAW_ComStat commstatus = pLink->GetCommStatus();

	if( commstatus !=CMST_TX_CNT &&

		commstatus !=CMST_NORMAL)

		return 0;

/*

	if(m_com_status == DEF_MSG_COMMDOWN)

	{

	}

*/

	//??ⶩ??״??

	//??ʼ?????Ƿ?Ҫһ?????͹?ȥ??????һ?????͵Ļ?????ʼ?ı??Ļ?ûȫ?????꣬???¶??ľ͹????ˡ?

	uint8 value = 0;

	//float fvalue;

	int nowtime = GetNowSecond();

//	if ((nowtime-m_LastSendTime) < 1)

//		return 1;

		//WYF 20190118

	PRawCtrl->GetAYx(m_rtuNO,3,&value);

	if ((2==value) && ((nowtime-m_LastSendTime) > m_RxTimeout))//WYF 20190118update???ճ?ʱʱ????Ϊ????ȫ???ݷ???ʱ??

		m_CallAlldata=1;

	if(value==1 && m_sendVentSubResqFlag==0 && m_StepFlag==1) //һ???ԶԷ?ֻ?ܽ???50?????ݣ????????132?????????η??͡?

	{

//		if ((nowtime-m_LastSendTime) < 1)

//			return 1;		

//if(strncmp(bEMCS,"YES",3)==0){	//WYF 20190104	

		PrintLog(LOG_INFORMATION,"֪ͨ?????ʼ????");

		if(m_ventStepFlag==1)

		{

			//PrintLog(LOG_INFORMATION,"?????ʼ????1-45");	

			getVentStatus();

			NotifyVent1Birth();

			m_ventStepFlag=2;

			return 1;

		}else if(m_ventStepFlag==2)

		{	//PrintLog(LOG_INFORMATION,"?????ʼ????46-90");		

			NotifyVent2Birth();

			m_ventStepFlag=3;

			return 1;

		}

		else

		{

			//PrintLog(LOG_INFORMATION,"?????ʼ????91-132");

			NotifyVent3Birth();

			m_sendVentSubResqFlag =1 ;

			m_ventStepFlag=1;

			m_StepFlag=2;

			return 1;

		}		

	}

	else if(value ==2 && m_StepFlag==1)

	{

		//PrintLog(LOG_INFORMATION,"֪ͨ??????±???");	

		if(m_ventStepFlag==1)

		{

			//PrintLog(LOG_INFORMATION,"??????±???1-45");

			getVentStatus();

			NotifyVent1Update();

			m_ventStepFlag=2;

			return 1;

		}

		else if(m_ventStepFlag==2)

		{//	PrintLog(LOG_INFORMATION,"??????±???46-90");		

			NotifyVent2Update();

			m_ventStepFlag=3;

			return 1;

		}

		else

		{

		//	PrintLog(LOG_INFORMATION,"??????±???91-132");

			NotifyVent3Update();

			m_sendVentSubResqFlag =1 ;

			m_ventStepFlag=1;

			m_StepFlag=2;

			return 1;

		}	

	}

//}//WYF 20190104

//if(strncmp(bPSCADA,"YES",3)==0){//WYF 20190104

//	if(strncmp(bEMCS,"YES",3)!=0)m_StepFlag=2;//WYF 20190104

	value = 0;

	PRawCtrl->GetAYx(m_rtuNO,5,&value);

	//m_rollingFlag = POWERSECTIONSTATUS_START;

	if(value == 1 && m_sendPowerSubResqFlag == 0&& m_StepFlag==2)

	{

		PrintLog(LOG_INFORMATION,"???????γ?ʼ????");	

		getPowerStatus();

		NotifyPowerBirth();

		m_sendPowerSubResqFlag = 1 ;

		if(strncmp(bFAS,"YES",3)==0)

		m_StepFlag=3;//SHL6789=1;//SHL5=3;//WYF 20190103 6789?޻???Ҫ??

		else{

//			if(strncmp(bEMCS,"YES",3)==0)

			m_StepFlag=1;

//			else

//			m_StepFlag=2;

		}

		return 1;

	}

	else if(value == 2&& m_StepFlag==2)

	{

		//PrintLog(LOG_INFORMATION,"???????θ??±???");	

		getPowerStatus();

		NotifyPowerUpdate();

		if(strncmp(bFAS,"YES",3)==0)

		m_StepFlag=3;//SHL6789=1;//SHL5=3;//WYF 20190103 6789?޻???Ҫ??

		else{

//			if(strncmp(bEMCS,"YES",3)==0)

			m_StepFlag=1;

			if(0<m_CallAlldata)m_CallAlldata=0;//WYF 20190118

//			else

//			m_StepFlag=2;

		}

		return 1;

	}

//}//WYF 20190104

if(strncmp(bFAS,"YES",3)==0){//WYF 20190104

	value = 0;

	PRawCtrl->GetAYx(m_rtuNO,1,&value);

	//m_rollingFlag = FIRESTATUS_START;

	if(value == 1 && m_sendFireSubResqFlag == 0&& m_StepFlag==3)

	{

		PrintLog(LOG_INFORMATION,"???ֳ?ʼ????");	

		getFireStatus();

		NotifyFireBirth();

		m_sendFireSubResqFlag = 1;

		m_StepFlag=1;

		return 1;

	}

	else if(value ==2&& m_StepFlag==3)

	{

		//PrintLog(LOG_INFORMATION,"???ָ??±???");

		//NotifyUpdate(SUB_FIRE);

		getFireStatus();

		NotifyFireUpdate();	

		m_StepFlag=1;

		if(0<m_CallAlldata)m_CallAlldata=0;//WYF 20190118

		return 1;

	}

}//WYF 20190104

//else//WYF 20190104

//	m_StepFlag=1;//WYF 20190104

	return 1;

}

/*

typedef  struct S_RDB_ZFYx{

	uint16		zfrtuno;

	uint16		YxNo;

	sint16		sr_rtuno;

	sint16		sr_yxno;

	uint8		freverse;	//?Ƿ?ȡ??

	uint8		OldVal;

	uint8		Val;

	uint32		changetime;

	uint8		chgFlag;			//<xyanglee>200705 ?ı??־

}S_RDB_ZFYx;

*/

sint32 Gena_Notify::RxProc()

{

	sint32 rtuno			=	pLink->GetRtuNo();

	unsigned char rtuaddr		=	pRtu->GetRtuAddr(rtuno);

	int buflen=pRxBuf->GetReadableSize();

	int nowtime=GetNowSecond();

	E_RAW_ComStat coms = pLink->GetCommStatus();

//	if ( coms ==CMST_RX_CNT && (nowtime-m_lastSubTime) >= 50)

	if ( coms ==CMST_RX_CNT && (nowtime-m_LastSendTime) >= m_RxTimeout)//50)//WYF 20190118

	{		

		//??ʱ???ط???ֱ????????һ???ն?

		pRxBuf->Move(buflen);

		pLink->RegisterFrm(FRAME_RX_TIMEOUT);

		pLink->SetCommStatus(CMST_NORMAL);

		PrintLog(LOG_INFORMATION,"???ճ?ʱ");

		return 1;

	}

	if (buflen<14)		//??????

	{

		//PrintLog(LOG_INFORMATION,"?????ݷ???");

		return 1;

	}

	int nRet= 0;

	uint8  buf[1024];

	memset(buf,0,1024);

	sint32 datalen = 0;

	sint32 contlen = 0;

 	while((buflen=pRxBuf->GetReadableSize())>0)

    {

		if(buflen > 1024)

			buflen = 1024;

        datalen = pRxBuf->Read(buf,buflen,DEF_BUFF_NOMOVE);

		contlen = m_Soap.ParseMessage((const char*)(buf),datalen);

		//PrintLog(LOG_INFORMATION,">>>>>????%s",buf);

		if(contlen<0)	//error

		{

			pRxBuf->Move(datalen);

			return 0;

		}

		if(contlen == 0)

			return 1;

		DataProcess();

		//PrintLog(LOG_INFORMATION,"ɾ??????%d",contlen);

		pRxBuf->Move(contlen);

		pLink->RegisterFrm(FRAME_RX_SUC);

		pLink->SetCommStatus(CMST_NORMAL);

    }

 	return 1;

}

void Gena_Notify::DataProcess()

{	

	HTTP_RESP_TYPE resptype = m_Soap.GetRespType();

	if(resptype == RESPTYPE_STATUS)//??ʼ???ijɹ???Ӧ?ɹ?????Ҫ????SID?????¶??ijɹ?????????

	{

		//m_waitRespFlag = 0 ;

		if(m_Soap.GetStatusCode() == 200)//??ӦOK

		{

			PrintLog(LOG_INFORMATION,"???յ???Ӧ200");

			m_responseFlag =1;

		}

		else //??Ӧ???????

		{

			PrintLog(LOG_INFORMATION,"???յ?http 1.1 %d",m_Soap.GetStatusCode());

			//m_responseFlag =1;

		}

	}

	else

	{

		PrintLog(LOG_INFORMATION,"???յ????????");

	}

}

void Gena_Notify::SetExtendedPara(uint16 no, sint32 val)

{

	if(no == 1)

	{

		m_rtuNO = val; //ȡ?ö???RTU??

		PrintLog(LOG_INFORMATION,"ȡ?ö???RTU??:%d",m_rtuNO);

	}

}

void 	Gena_Notify::NotifyVentBirth()

{

	int len = 0;

	char *pCode = NULL;

	for(int i=0;i<StaNum*4;i++)//132//WYF 20181231

	{		

		m_oldVent[i] = m_curVent[i];

		m_Soap.SetFanStatusContent(m_curVent[i]);

		//ȡ??sid??

		uint8 sid;

		PRawCtrl->GetAYx(m_rtuNO,4,&sid);

		m_Soap.SetSrvSID(sid);

//		pCode = m_Soap.NotifyUpdate(len);

		pCode = m_Soap.NotifyBirth(len);//WYF 20190118

		if(len>0)

		{			

			pTxBuf->Write((uint8*)pCode,len);			

			//pLink->SetCommStatus(CMST_RX_CNT);

		}	

	}

}

void 	Gena_Notify::NotifyVent1Birth()

{

	int len = 0;

	char *pCode = NULL;

	for(int i=0;i<MaxPacket;i++)//45//WYF 20181231

	{

		PrintLog(LOG_INFORMATION,"%d?ŷ????ʼ״̬:״̬%d,????%d",i+1,m_curVent[i].status,m_curVent[i].direction);

		m_oldVent[i] = m_curVent[i];

		m_Soap.SetFanStatusContent(m_curVent[i]);

		//ȡ??sid??

		uint8 sid;

		PRawCtrl->GetAYx(m_rtuNO,4,&sid);

		m_Soap.SetSrvSID(sid);

//		pCode = m_Soap.NotifyUpdate(len);

		pCode = m_Soap.NotifyBirth(len);//WYF 20190118

		if(len>0)

		{			

			pTxBuf->Write((uint8*)pCode,len);			

			//pLink->SetCommStatus(CMST_RX_CNT);

			m_LastSendTime = GetNowSecond();

		}	

	}

}

void 	Gena_Notify::NotifyVent2Birth()

{

	int len = 0;

	char *pCode = NULL;

	for(int i=MaxPacket;i<MaxPacket*2;i++)//45-90//WYF 20181231

	{

		PrintLog(LOG_INFORMATION,"%d?ŷ????ʼ???״̬:״̬%d,????%d",i+1,m_curVent[i].status,m_curVent[i].direction);

		m_oldVent[i] = m_curVent[i];

		m_Soap.SetFanStatusContent(m_curVent[i]);

		//ȡ??sid??

		uint8 sid;

		PRawCtrl->GetAYx(m_rtuNO,4,&sid);

		m_Soap.SetSrvSID(sid);

//		pCode = m_Soap.NotifyUpdate(len);

		pCode = m_Soap.NotifyBirth(len);//WYF 20190118

		if(len>0)

		{			

			pTxBuf->Write((uint8*)pCode,len);			

			//pLink->SetCommStatus(CMST_RX_CNT);

			m_LastSendTime = GetNowSecond();

		}	

	}

}

void 	Gena_Notify::NotifyVent3Birth()

{

	int len = 0;

	char *pCode = NULL;

	for(int i=MaxPacket*2;i<StaNum*4;i++)//90-132//WYF 20181231

	{

		PrintLog(LOG_INFORMATION,"%d?ŷ????ʼ???״̬:״̬%d,????%d",i+1,m_curVent[i].status,m_curVent[i].direction);

		m_oldVent[i] = m_curVent[i];

		m_Soap.SetFanStatusContent(m_curVent[i]);

		//ȡ??sid??

		uint8 sid;

		PRawCtrl->GetAYx(m_rtuNO,4,&sid);

		m_Soap.SetSrvSID(sid);

//		pCode = m_Soap.NotifyUpdate(len);

		pCode = m_Soap.NotifyBirth(len);//WYF 20190118

		if(len>0)

		{			

			pTxBuf->Write((uint8*)pCode,len);			

			//pLink->SetCommStatus(CMST_RX_CNT);

			m_LastSendTime = GetNowSecond();

		}	

	}

}

void 	Gena_Notify::NotifyFireBirth()

{

	int len = 0;

	char *pCode = NULL;

	ST_FIRE_ALARM st_fire;

	for(int i=0;i<StaNum;i++)//33

	{

		m_oldFire[i] = m_curFire[i];

		st_fire.objid = i+1;

		if((12-1)<=i && i<=(19-1))st_fire.objid += 90;//WYF 20190630 5????12-19վ????Ӧ102-109վid

		st_fire.stat_flag=1;

		st_fire.status=m_curFire[i];

		PrintLog(LOG_INFORMATION,"%d?Ż𾯳?ʼ״̬:״̬%d",i+1,m_curFire[i]);

		m_Soap.SetFireAlarmContent(st_fire);

		//ȡ??sid??

		uint8 sid;

		PRawCtrl->GetAYx(m_rtuNO,2,&sid);

		m_Soap.SetSrvSID(sid);

//		pCode = m_Soap.NotifyUpdate(len);

		pCode = m_Soap.NotifyBirth(len);//WYF 20190118

		if(len>0)

		{			

			pTxBuf->Write((uint8*)pCode,len);			

			//pLink->SetCommStatus(CMST_RX_CNT);

			m_LastSendTime = GetNowSecond();

		}	

	}

}

void 	Gena_Notify::NotifyPowerBirth()

{

	int len = 0;

	char *pCode = NULL;

	ST_POWERSECTION st_power;

	for(int i=0;i<StaNum*2;i++)//28 WYF 20190103

	{

		PrintLog(LOG_INFORMATION,"%d?ŵ??????γ?ʼ״̬:״̬%d",i+1,m_curPower[i]);

		m_oldPower[i] = m_curPower[i];

		st_power.objid = i+1;

		st_power.stat_flag=1;

		st_power.status=m_curFire[i];

		m_Soap.SetPowerSectionContent(st_power);

		//ȡ??sid??

		uint8 sid;

		PRawCtrl->GetAYx(m_rtuNO,6,&sid);

		m_Soap.SetSrvSID(sid);

//		pCode = m_Soap.NotifyUpdate(len);

		pCode = m_Soap.NotifyBirth(len);//WYF 20190118

		if(len>0)

		{			

			pTxBuf->Write((uint8*)pCode,len);			

			//pLink->SetCommStatus(CMST_RX_CNT);

			m_LastSendTime = GetNowSecond();

		}	

	}

}

void	Gena_Notify::NotifyVentUpdate()

{

	int len = 0;

	char *pCode = NULL;

	for(int i=0;i<StaNum*4;i++)//132//WYF 20181231

	{

		if(1>m_CallAlldata){//??30-60sʱ??ȫ???ݷ???

		if(m_oldVent[i].status == m_curVent[i].status && m_oldVent[i].direction == m_curVent[i].direction)

			continue;

		}

		m_oldVent[i] = m_curVent[i];

		m_Soap.SetFanStatusContent(m_curVent[i]);

		//ȡ??sid??

		uint8 sid;

		PRawCtrl->GetAYx(m_rtuNO,4,&sid);

		m_Soap.SetSrvSID(sid);

		pCode = m_Soap.NotifyUpdate(len);

		if(len>0)

		{			

			pTxBuf->Write((uint8*)pCode,len);			

			//pLink->SetCommStatus(CMST_RX_CNT);

			m_LastSendTime = GetNowSecond();

		}	

	}

}

void	Gena_Notify::NotifyVent1Update()

{

	int len = 0;

	char *pCode = NULL;

	for(int i=0;i<MaxPacket;i++)//45//WYF 20181231

	{

		if(1>m_CallAlldata){//??30-60sʱ??ȫ???ݷ???

		if(m_oldVent[i].status == m_curVent[i].status && m_oldVent[i].direction == m_curVent[i].direction)

			continue;

		}

		PrintLog(LOG_INFORMATION,"%d?ŷ?????·??״̬:״̬%d,????%d",i+1,m_curVent[i].status,m_curVent[i].direction);

		m_oldVent[i] = m_curVent[i];

		m_Soap.SetFanStatusContent(m_curVent[i]);

		//ȡ??sid??

		uint8 sid;

		PRawCtrl->GetAYx(m_rtuNO,4,&sid);

		m_Soap.SetSrvSID(sid);

		pCode = m_Soap.NotifyUpdate(len);

		if(len>0)

		{			

			pTxBuf->Write((uint8*)pCode,len);			

			//pLink->SetCommStatus(CMST_RX_CNT);

			m_LastSendTime = GetNowSecond();

		}	

	}

}

void	Gena_Notify::NotifyVent2Update()

{

	int len = 0;

	char *pCode = NULL;

	for(int i=MaxPacket;i<MaxPacket*2;i++)//45-90//WYF 20181231

	{

		if(1>m_CallAlldata){//??30-60sʱ??ȫ???ݷ???

		if(m_oldVent[i].status == m_curVent[i].status && m_oldVent[i].direction == m_curVent[i].direction)

			continue;

		}

		PrintLog(LOG_INFORMATION,"%d?ŷ?????·??״̬:״̬%d,????%d",i+1,m_curVent[i].status,m_curVent[i].direction);

		m_oldVent[i] = m_curVent[i];

		m_Soap.SetFanStatusContent(m_curVent[i]);

		//ȡ??sid??

		uint8 sid;

		PRawCtrl->GetAYx(m_rtuNO,4,&sid);

		m_Soap.SetSrvSID(sid);

		pCode = m_Soap.NotifyUpdate(len);

		if(len>0)

		{			

			pTxBuf->Write((uint8*)pCode,len);			

			//pLink->SetCommStatus(CMST_RX_CNT);

			m_LastSendTime = GetNowSecond();

		}	

	}

}

void	Gena_Notify::NotifyVent3Update()

{

	int len = 0;

	char *pCode = NULL;

	for(int i=MaxPacket*2;i<StaNum*4;i++)//90-132//WYF 20181231

	{

		if(1>m_CallAlldata){//??30-60sʱ??ȫ???ݷ???

		if(m_oldVent[i].status == m_curVent[i].status && m_oldVent[i].direction == m_curVent[i].direction)

			continue;

		}

		PrintLog(LOG_INFORMATION,"%d?ŷ?????·??״̬:״̬%d,????%d",i+1,m_curVent[i].status,m_curVent[i].direction);

		m_oldVent[i] = m_curVent[i];

		m_Soap.SetFanStatusContent(m_curVent[i]);

		//ȡ??sid??

		uint8 sid;

		PRawCtrl->GetAYx(m_rtuNO,4,&sid);

		m_Soap.SetSrvSID(sid);

		pCode = m_Soap.NotifyUpdate(len);

		if(len>0)

		{			

			pTxBuf->Write((uint8*)pCode,len);			

			//pLink->SetCommStatus(CMST_RX_CNT);

			m_LastSendTime = GetNowSecond();

		}	

	}

}

void	Gena_Notify::NotifyFireUpdate()

{	

	int len = 0;

	char *pCode = NULL;

	ST_FIRE_ALARM st_fire;

	for(int i=0;i<StaNum;i++)//33

	{

		if(1>m_CallAlldata){//??30-60sʱ??ȫ???ݷ???

		if(m_oldFire[i] == m_curFire[i])

			continue;

		}

	PrintLog(LOG_INFORMATION,"%d?Ż𾯸???״̬:״̬%d",i+1,m_curFire[i]);

		m_oldFire[i] = m_curFire[i];

		st_fire.objid = i+1;

		if((12-1)<=i && i<=(19-1))st_fire.objid += 90;//WYF 20190630 5????12-19վ????Ӧ102-109վid

		st_fire.stat_flag=1;

		st_fire.status=m_curFire[i];

		m_Soap.SetFireAlarmContent(st_fire);

		//ȡ??sid??

		uint8 sid;

		PRawCtrl->GetAYx(m_rtuNO,2,&sid);

		m_Soap.SetSrvSID(sid);

		pCode = m_Soap.NotifyUpdate(len);

		if(len>0)

		{			

			pTxBuf->Write((uint8*)pCode,len);			

			//pLink->SetCommStatus(CMST_RX_CNT);

			m_LastSendTime = GetNowSecond();

		}	

	}

}

void	Gena_Notify::NotifyPowerUpdate()

{

	int len = 0;

	char *pCode = NULL;

	ST_POWERSECTION st_power;

	for(int i=0;i<StaNum*2;i++)//28 WYF 20190103

	{

		if(1>m_CallAlldata){//??30-60sʱ??ȫ???ݷ???

		if(m_oldPower[i] == m_curPower[i])

			continue;

		}

		PrintLog(LOG_INFORMATION,"%d?ŵ??????θ???״̬:״̬%d",i+1,m_curPower[i]);

		m_oldPower[i] = m_curPower[i];

		st_power.objid = i+1;

		st_power.stat_flag=1;

		st_power.status=m_curPower[i];

		m_Soap.SetPowerSectionContent(st_power);

		//ȡ??sid??

		uint8 sid;

		PRawCtrl->GetAYx(m_rtuNO,6,&sid);

		m_Soap.SetSrvSID(sid);

		pCode = m_Soap.NotifyUpdate(len);

		if(len>0)

		{			

			pTxBuf->Write((uint8*)pCode,len);			

			//pLink->SetCommStatus(CMST_RX_CNT);

			m_LastSendTime = GetNowSecond();

		}	

	}

}

void	Gena_Notify::NotifyDeath(SUB_ENUM subObj)

{

	//??ô?ж??Ƿ??ͽ???????

	//??ת??????ȡ?????ݣ?Ȼ??ת????ATS

}

void    Gena_Notify::getFireStatus()

{

	CEasyList *yxlist=pZfDataCtrl->GetYxStructList();

	sint32 numYx = yxlist->GetListLen();

	uint8 yxVal=0,yxVal1=0;

	if(numYx<=0)

	{

		return ;	

	}

	S_RDB_ZFYx *yxinfo,*yxinfo1;

	int i=0;

	//1---33ң?ź?Ϊ33????վ??״̬?? 34 ---66Ϊ????????״̬?? 67?Ժ?Ϊ?????з??״̬??...?Դ?????..

	for(i=0;i<StaNum;i++)//

	{

		m_curFire[i] = 0;

		yxinfo=(S_RDB_ZFYx *)((*yxlist)[FIRESTATUS_START+i*2]);

PRawCtrl->GetAYx(yxinfo->sr_rtuno,yxinfo->sr_yxno,&yxVal);//WYF 20190103

		yxinfo1=(S_RDB_ZFYx *)((*yxlist)[FIRESTATUS_START+i*2+1]);

PRawCtrl->GetAYx(yxinfo1->sr_rtuno,yxinfo1->sr_yxno,&yxVal1);//WYF 20190103

//		if(yxinfo->Val>0 && yxinfo1->Val==1)

		if(yxVal>0 && yxVal1==1)

		{

			m_curFire[i] = 1;				

		}/*

		else if(yxinfo->Val==0 && yxinfo1->Val==1)

		{

			m_curFire[i] = 0;				

		}

		else{

			m_curFire[i] = 2;

		}*/

	}	

	return ;

}

void    Gena_Notify::getVentStatus()

{

	CEasyList *yxlist=pZfDataCtrl->GetYxStructList();

	sint32 numYx = yxlist->GetListLen();

	if(numYx<=0)

	{

		return ;	

	}	

	uint8 yxVal=0,yxVal1=0,yxVal2=0;

	S_RDB_ZFYx *yxinfo,*yxinfo1;

	int i=0;

	for(i=0;i<StaNum*4;i++)//132//WYF 20181231

	{

		m_curVent[i].direct_flag =0;

		m_curVent[i].direction=0;

		m_curVent[i].stat_flag=0;

		m_curVent[i].status=0;

		m_curVent[i].objid = i+1;

		yxinfo=(S_RDB_ZFYx *)((*yxlist)[VENTSTATUS_START+i*4]);//???ϵ?//0Ϊ?ǹ??ϣ?1Ϊ????

		PRawCtrl->GetAYx(yxinfo->sr_rtuno,yxinfo->sr_yxno,&yxVal);//WYF 20190103

		if(/*yxinfo->Val*/yxVal == 1)		

		{		

			m_curVent[i].stat_flag = 1;

			m_curVent[i].status = 2;//??SetFanStatusContent??????status=0Ϊֹͣ 1Ϊ???? 2Ϊ???ϣ????õ??Ϊ2??"Fault"

			//PrintLog(LOG_INFORMATION,"?????????ʼ????,?????:%d,???????",fanStatus.objid);				

		}

		else

		{

			yxinfo=(S_RDB_ZFYx *)((*yxlist)[VENTSTATUS_START+i*4+1]);//ֹͣ??

			m_curVent[i].stat_flag = 1;	

			PRawCtrl->GetAYx(yxinfo->sr_rtuno,yxinfo->sr_yxno,&yxVal);//WYF 20190103

			if(/*yxinfo->Val*/yxVal == 0)//???Ϊ??״̬?????жϷ??????

			{			

				yxinfo=(S_RDB_ZFYx *)((*yxlist)[VENTSTATUS_START+i*4+2]);//??????????е?

PRawCtrl->GetAYx(yxinfo->sr_rtuno,yxinfo->sr_yxno,&yxVal);//WYF 20190103

				yxinfo1=(S_RDB_ZFYx *)((*yxlist)[VENTSTATUS_START+i*4+3]);//??????????е?

PRawCtrl->GetAYx(yxinfo1->sr_rtuno,yxinfo1->sr_yxno,&yxVal1);//WYF 20190103

//				if(yxinfo->Val == yxinfo1->Val)

				if(yxVal == yxVal1)

				{

					m_curVent[i].status = 2;//	???????

				}

				else

				{

					m_curVent[i].status = 1;//	???????					

					m_curVent[i].direct_flag = 1;

					if(/*yxinfo->Val*/yxVal == 1)

					{								

						m_curVent[i].direction = 1;//????Ϊ1	

					}

					else

					{

						m_curVent[i].direction = 0;	

					}

					//PrintLog(LOG_INFORMATION,"?????????ʼ????,?????:%d,״̬%d",m_curVent[i].objid,m_curVent[i].direction);

				}

			}

			else

			{					

				m_curVent[i].status = 0;//

				//PrintLog(LOG_INFORMATION,"?????????ʼ????,?????:%d,??",m_curVent[i].objid);

			}

		}

	}

}

void	Gena_Notify::getPowerStatus()

{

	int power[STANUMS*4];//WYF 20190103

	int i=0;

	uint8 yxVal=0,yxVal1=0,yxVal2=0,yxVal3=0,yxVal4=0,yxVal5=0,yxVal6=0;

	float32 ycVal=0,ycVal1=0;

	CEasyList *yxlist=pZfDataCtrl->GetYxStructList();

	sint32 numYx = yxlist->GetListLen();

	CEasyList *yclist=pZfDataCtrl->GetYcStructList();

	sint32 numYc = yclist->GetListLen();

	if(numYx<=0||numYc<=0)