monitor.cpp

MDF监控源码2

// Monitor.cpp : 实现文件
//

#include "stdafx.h"
#include <afxmt.h>
#include <afx.h>
#include "MDF.h"
#include ".\monitor.h"
#include "ptcweb.h"
#include ".\media.h"
#include ".\dacircle.h"
#include ".\dacable.h"
#include ".\dapowerdc.h"
#include ".\dapowerac.h"
#include ".\httpaccess.h"

//#include "..\Global\tcpbase.h"
// CMonitor 对话框

IMPLEMENT_DYNAMIC(CMonitor, CWnd)
extern CMDFApp theApp ;

//static UINT indicators[] =
//{
//	ID_SEPARATOR,           // 状态行指示器
//	ID_INDICATOR_CAPS,
//	ID_INDICATOR_NUM,
//	ID_INDICATOR_SCRL,
//};



//##ModelId=4652869F01C5
CMonitor::CMonitor()
{
	/******************************************************************/
	//初始化通讯组件
	
	CreateEx(NULL,"#32770",NULL,WS_CAPTION | WS_TILEDWINDOW,0,0,1,1,NULL,NULL);
	strReceive.Empty();
	p_adodb = theApp.m_pAdoDB;
	memset(buff,0,MAX_SIZE);
	iRev = 0;

	m_thdAnalyseStatus = FALSE;						//结束线程变量
	m_AskingClose = m_thdAnalyseClose = FALSE;		//线程关闭参数

	m_protocol = new CProtocol();					//协议处理包
	m_pEQPool = new CEQPool();						//设备管理包
	m_pEQPool->InitUnitList();						//初始化设备列表

	m_ListInfo = new CListInfoFrame();
	
	/*	调试时注释	2007-6-12

	m_pAnalyse = new CDataAnalyse();	//数据分析包	
	m_pAnalyse->SetParent(this);
	
	m_AskingStatus	= FALSE;			//轮巡监测线程状态

	*/

	m_hEventArray[0] = CreateEvent(NULL, TRUE, FALSE, "Close");
	m_hEventArray[1] = CreateEvent(NULL, TRUE, FALSE, "Reset");
	m_hEventArray[2] = CreateEvent(NULL, TRUE, FALSE, "Send");


}

//##ModelId=4652869F01C6
CMonitor::~CMonitor()
{
	//删除
	if (m_protocol)
		delete m_protocol;			//协议处理包
	if(m_pEQPool)
		delete m_pEQPool;			//设备管理包
	//if(m_pAnalyse)
	//	delete m_pAnalyse;			//数据分析包	

}


BEGIN_MESSAGE_MAP(CMonitor, CWnd)
//{{AFX_MSG_MAP(CMDFDlg)
	ON_MESSAGE(WM_SOCK_RXSTRING,onSockReadString)		//SOCKET 读数据
	ON_MESSAGE(WM_COMM_RXCHAR,onCom_RXChar)				//串口 读数据
	ON_MESSAGE(WM_STATUS_CHANGE,onStatusChange)			//设备状态改变
	ON_MESSAGE(WM_DEVICE_ALARM,onAlarming)				//设备发生告警
	ON_MESSAGE(WM_DEVICE_DATA,onReadData)				//设备发生告警
	
	ON_MESSAGE(WM_GSMMSG,onSendSMSInfo)					//发送收机短信

	ON_MESSAGE(MM_WOM_OPEN,onSoundOpen)					//开始播放声音
	ON_MESSAGE(MM_WOM_DONE,onSoundDone)					//播放声音中
	ON_MESSAGE(MM_WOM_CLOSE,onSoundClose)				//播放声音结束
	ON_MESSAGE(WM_VOICE, GsmVoice)						//GSM播放声音
	ON_MESSAGE(WM_VOICE_CLOSE, GsmVoiceClose)			//GSM声音关闭

	ON_WM_CREATE()
	ON_WM_SIZE()
	ON_COMMAND(ID_CM_START, OnCmStart)
	ON_COMMAND(ID_CM_STOP, OnCmStop)
	ON_COMMAND(ID_APP_EXIT, OnAppExit)

//}}AFX_MSG_MAP

//ON_BN_CLICKED(IDOK, OnBnClickedOk)
//ON_BN_CLICKED(IDC_BUTTON1, OnBnClickedButton1)
//ON_BN_CLICKED(IDCANCEL, OnBnClickedCancel)
ON_COMMAND(ID_CM_SOUND, OnCmSound)
END_MESSAGE_MAP()


// CMonitor 消息处理程序



// 起动系统监测功能


//##ModelId=4652869F02B3
BOOL CMonitor::StartMonitoring(void)
{
	CString strCom;
	BOOL blRet = FALSE;

	HANDLE hThreadID = 0;

	DWORD dwCommEvents =0;
	dwCommEvents  |= EV_BREAK;
	dwCommEvents  |= EV_CTS;
	dwCommEvents  |= EV_DSR;
	dwCommEvents  |= EV_ERR;
	dwCommEvents  |= EV_RING;
	dwCommEvents  |= EV_RLSD;
	dwCommEvents  |= EV_RXCHAR;
	dwCommEvents  |= EV_RXFLAG;
	dwCommEvents  |= EV_TXEMPTY;

	//起动WEB端口监测服务
	m_udpServer[0] = new CSocketComm();
	m_udpServer[0]->SetMessageWindow(this);
	m_udpServer[0]->StartMonitoring(theApp.m_Baseinfo.ServerPort);
	
	//起动监测设备端口监测服务
	m_udpServer[1] = new CSocketComm();
	m_udpServer[1]->SetMessageWindow(this);
	m_udpServer[1]->StartMonitoring(theApp.m_Baseinfo.DevicePort);
	
	CSerialPort *sport;

	GetComPort();				//取得现有设备的通信端口
	if (m_comArray.GetCount()>0)
	{
		for(int i=0;i<m_comArray.GetCount();i++)
		{
			strCom = m_comArray.GetAt(i);
			strCom.Replace("COM","");
			sport = new CSerialPort();
			blRet = sport->InitPort(this,atoi(strCom.GetBuffer()),4800,'N',8,1,dwCommEvents,512);		
			if (blRet == TRUE)
			{
				blRet = sport->StartMonitoring();
				m_comPort.Add(sport);
				TRACE("串口监测开始...");
			}else
			{
				TRACE("串口起动监测失败...");
				delete sport;
				blRet = FALSE;
			}
		}
	}

	return blRet;
}

// 停止系统监测功能
//##ModelId=4652869F02BF
BOOL CMonitor::StopMonitoring(void)
{
	BOOL bResul = FALSE;
	//停止UDP通信

	//停止轮循线程
	SetEvent(m_hEventArray[0]);
	Sleep(500);
	DWORD dwStart,dwEnd;
	dwEnd = dwStart = GetTickCount();
	while (m_AskingStatus && (dwEnd - dwStart < 10000))
	{
		dwEnd = GetTickCount();
		Sleep(100);
	}


	bResul = this->m_udpServer[0]->StopMonitoring();
	//bResul = this->m_udpServer[0]->ClosePort();
	//if (bResul)
	//	TRACE0("停止WEB端监测服务成功...");

	bResul = this->m_udpServer[1]->StopMonitoring();
	//bResul = this->m_udpServer[1]->ClosePort();
	//if (bResul)
	//	TRACE0("停止设备端UDP监测服务成功...");
	

	//停止串口通信线程
	if (!m_AskingStatus)
	{
		CSerialPort *m_port;
		for(int i=0;i<m_comPort.GetCount();i++)
		{
			m_port = (CSerialPort *) m_comPort.GetAt(i);
			bResul = m_port->CloseMonitoring();
			bResul = m_port->ClosePort();
			if (bResul)
			{
				delete m_port;
				bResul = TRUE;
			}
			else
			{
				bResul = FALSE;
			}
		}
		m_comPort.RemoveAll();

	}else
		bResul = FALSE;

	//m_udpServer[1]->ClosePort();
	//m_udpServer[0]->ClosePort();
	

	return bResul;
}

// 重新起动监测功能
//##ModelId=4652869F02CE
int CMonitor::Restart(void)
{
	return 0;
}

// 关闭监测功能
//##ModelId=4652869F02DE
BOOL CMonitor::Close(void)
{
	//m_udpServer[0]->StopMonitoring();
	//m_udpServer[1]->StopMonitoring();
	StopMonitoring();
	PostQuitMessage(0);
	return TRUE;

}


// Socket接收消息
//##ModelId=4652869F0203
LRESULT CMonitor::onSockReadString(WPARAM wParam, LPARAM lParam)
{
	CString sBuf;
	//CInfoFrame frame;
	sMsgBody  *msgBody;
	CInfoFrame *frame;
	frame = new CInfoFrame;
	
	//填充包结构
	msgBody = (sMsgBody *)wParam;
	sBuf = CString(msgBody->lpBuf,msgBody->iLen);
	memcpy(frame->ucBuf,msgBody->lpBuf,msgBody->iLen);
	frame->ucBuf[msgBody->iLen] = '\0';
	frame->address = msgBody->sIP;
	frame->addrType = COMM_UDP;
	frame->iPort = msgBody->iPort;
	frame->nRLen = msgBody->iLen;
	frame->time = CTime::GetCurrentTime();
	frame->unState = 0;

	//把消息体放入到队列表
	m_ListInfo->AddInfobody(*frame);  
	if (!m_thdAnalyseStatus)
		StartAnalyseing();

	/*
	if ((int)lParam == theApp.m_Baseinfo.DevicePort)
	{
		DataAnalyse(*frame);
	}else 	//WEB数据分析
	{
		WebDataAnalyse(*frame);									//处理方法
	}
	*/

	//delete frame;
	return LRESULT();
}

//##ModelId=4652869F01F4
LRESULT CMonitor::onCom_RXChar(WPARAM wParam, LPARAM lParam)
{
	CString sBuf,strTemp,strPort;
	char *cRet;
	sMsgBody *msgBody;
	CInfoFrame *frame;
	int iPort,iLen;
	msgBody = (sMsgBody *)wParam;

	cRet = new char[msgBody->iLen + 1];
	iLen = msgBody->iLen;
	memcpy(cRet,msgBody->lpBuf ,iLen);
	cRet[iLen] = '\0';
	iPort = (int)lParam;
	int  pStart,pEnd;
	pStart = pEnd = 0;

	sBuf = strReceive;
	
	//TRACE0(cRet);
	//CMutex mutex;
	sBuf += cRet;
	pStart = sBuf.Find(0x7e);
	sBuf = sBuf.Mid(pStart);
	strTemp = sBuf;
	pEnd = strTemp.Find(0xd) ;
	strReceive = sBuf.Mid(pEnd + 1);
	
	if (pEnd > 1 )
	{
		strTemp = strTemp.Left(pEnd);
		TRACE0(strTemp +'\n');

		//记录日志文件
		/****************************************************************/
		//theApp.WriteTxtLog(strTemp);
		/****************************************************************/

		//填充包结构
		frame = new CInfoFrame;
		frame->address.Format("COM%d",iPort);				//记录通信的原地址
		frame->addrType = COMM_COM;							//通信方式
		frame->iPort = iPort;
		frame->nRLen = strTemp.GetLength();
		memcpy(frame->ucBuf,strTemp.GetBuffer(),frame->nRLen );
		frame->time = CTime::GetCurrentTime();
		frame->unState = 0;
		frame->ucBuf[strTemp.GetLength()] = '\0';
		TRACE0(frame->ucBuf);
		//把消息体放到队列中
		m_ListInfo->AddInfobody(*frame);  
		if (!m_thdAnalyseStatus)
			StartAnalyseing();

		//取得最后一次送出的命令字
		//DataAnalyse(*frame);
		//delete frame;
	}
	return LRESULT();
}

// 取得监测串口号
//##ModelId=4652869F030D
int CMonitor::GetComPort(void)
{
	CString sSql,sTip,strField ;
	_RecordsetPtr pRst;
	_variant_t vt,vtTmp;
	m_comArray.RemoveAll();
	//选择通讯方式为RS232的设备都用了那些串口
	//sSql = "SELECT UPPER(monitorAddrSource) AS monitorAddrSource FROM CMTMonitorEqu where (monitorAddrSource Like 'COM%') AND monitorEquComModel in (0,3) And isUser = 1";
	sSql.Format("SELECT UPPER(monitorAddrSource) AS monitorAddrSource FROM CMTMonitorEqu where (monitorAddrSource Like 'COM%%') AND monitorEquComModel in (%d,%d) And isUser = 1",COMM_COM,COMM_485); 
	pRst.CreateInstance(__uuidof(Recordset));
	p_adodb->ReadDB(sSql,pRst,sTip);
	while(!pRst->adoEOF)
	{
		//需要检查串口是否存在
		p_adodb->GetFieldValue("monitorAddrSource",pRst,strField); 
		m_comArray.Add(strField);
		pRst->MoveNext();
	}
	pRst->Close();
	pRst.Release();
	return 0;
}


// 数据分析处理
//##ModelId=4652869F0321
int CMonitor::DataAnalyse(CInfoFrame frame)
{
	CString strError, strEQName, strTip, strTemp,strResult;
	CString strTime, strType, strNote, strData ,strMemo ; //数据库各字段
	CString strAddr ;
	int  iIndex; 
	CDACircle *m_daCircle;
	CDACable *m_daCable;
	CDAPowerDC *m_daPowerDC;
	CDAPowerAC *m_daPowerAC;
	//CPtcCable *m_pCable;
	//CPtcPowerDC *m_pPowerDC;
	tyCircle *m_circle; 
	tyCable *m_cable; 
	tyPowerDC *m_powerdc;		
	tyPowerAC *m_powerac;		
	sUnit m_unit;
	UCHAR ucRecvBuf[MAX_SIZE] ;
	//int nRecvLen ;
	//frame.ucBuf[frame.nRLen] = '\0';
	//try
	//{
		//存储原始数据包
		if (theApp.m_Baseinfo.SaveLog == 1)
			p_adodb->WriteCommRd(frame);

		//数据包展开
		int iRet = m_protocol->Explain(frame);
		if (iRet == 0)		//分析数据告警内容
		{
			for(int i=0;i<m_UnitArray.GetCount();i++)
			{
				m_unit = m_UnitArray.GetAt(i);
				//取得最近一次发送命令及发送数量，检查是否已经多次发送而没有回复。以此来确定是否在线
				if (m_unit.strIDAddr == (int)frame.InPack.ADR && m_unit.sIP == frame.address)
				{
					frame.iCmd = m_unit.iCmd;
					m_unit.iSendCount = 0;
					m_unit.iReceive++ ;
					m_unit.tmReceive = CTime::GetCurrentTime();
					break;
				}
			}
			//告警分析
			switch(frame.InPack.CID1 )
			{
			case EQU_CODE_MDF:				//MDF智能告警器
					CEquipmentPort *m_PortState;
					m_PortState = new CEquipmentPort;
					//m_PortState->AlarmState = PORT_NORMAL;
					//m_pAnalyse->AnalyseAlarm(frame,*m_PortState);
					//delete m_PortState; 
				break;	
			case EQU_CODE_CABLE:			//电缆检测单元
				m_daCable = new CDACable() ;
				m_daCable->SetParent(this);
				m_daCable->SetDBAccess((LPVOID)p_adodb);
				//取得该设备
				iIndex = m_pEQPool->GetCableItem(m_CableList, frame.InPack.ADR,frame.addrType ,frame.iPort );
				//分析数据
				if (iIndex >= 0)
				{
					m_cable = &(tyCable)m_CableList.GetAt( iIndex);
					m_daCable->AnalyseAlarm(frame,(LPVOID)m_cable,strResult);
					m_CableList.SetAt(iIndex, *m_cable);
				}
				delete m_daCable;
				break;
			case EQU_CODE_INDUCTCIRCLE:		//强电入侵监测模块(工频环)
				
				m_daCircle = new CDACircle() ;
				m_daCircle->SetParent(this);
				m_daCircle->SetDBAccess((LPVOID)p_adodb);
				//取得该设备
				iIndex = m_pEQPool->GetCircleItem(m_CircleList, frame.InPack.ADR,frame.addrType ,frame.iPort );
				//分析数据
				if (iIndex >= 0)
				{
				m_circle = &(tyCircle)m_CircleList.GetAt( iIndex);
				m_daCircle->AnalyseAlarm(frame,(LPVOID)m_circle,strResult);
				m_CircleList.SetAt(iIndex, *m_circle);
				}
				delete m_daCircle;

				break;
			case EQU_CODE_ACPOWERCABINET:	//交流电源分配柜

				//m_powerac = new tyPowerAC;
				m_daPowerAC = new CDAPowerAC() ;
				m_daPowerAC->SetParent(this);
				m_daPowerAC->SetDBAccess((LPVOID)p_adodb);