www.pudn.com > gps-time.rar > Communication.cpp
// Communication.cpp: implementation of the CCommunication class.
//
//////////////////////////////////////////////////////////////////////
#include "stdafx.h"
#include "RegionComm.h"
#include "Communication.h"
#include "Comthrd.h"
#include "procdatathrd.h"
#include "RegionSocket.h"
#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif
extern NEAR bool bDogServerAskMeExit;//lv 2003 5 17 add
extern NEAR bool bUserActive[20];
extern NEAR HANDLE hSetUser[20];
extern NEAR int iUsers;
//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////
CCommunication::CCommunication()
{
m_cRegionNo = 1;
m_pServerSocket = (CRegionSocket *) new CRegionSocket(this);
m_aProcessEvent.RemoveAll();m_aReceiveEvent.RemoveAll();
m_pCommThread=NULL;m_pProcessThread=NULL;
}
CCommunication::~CCommunication()
{
for (int i = 0; i < m_aCom.GetSize(); i++)
delete m_aCom[i];
m_aCom.RemoveAll();
m_aProcessEvent.RemoveAll();
m_aReceiveEvent.RemoveAll();
if(m_pServerSocket!=NULL)
delete m_pServerSocket;
}
//增加设备
BOOL CCommunication::AddTscCom(BYTE PortNo,DWORD dwBaudRate,BYTE DeviceType,BYTE DeviceNo,CString Depict)
{
int i;
CComPort * pComPort;
if(!CreateThreadEvents())
return(FALSE);
CSingleLock commLock(&muxCommArray);
commLock.Lock(); //访问端口对象
for (i = 0; i < m_aCom.GetSize(); i++)
if (m_aCom[i]->m_ComPort == PortNo)
return FALSE;
pComPort = (CComPort *) new CComPort(this);
pComPort->SetPamera(PortNo,dwBaudRate,DeviceType,DeviceNo,Depict);
if (!pComPort->Open())
{
delete pComPort;
return FALSE;
}
try
{
m_aCom.Add(pComPort);
m_aReceiveEvent.Add( pComPort->GetReceiveEvent());
m_aProcessEvent.Add(pComPort->m_hProcessEvent);
}
catch(CMemoryException *eMem)
{
eMem->Delete();
delete pComPort;
return(FALSE);
}
//以下分别通知通信和处理线程
if(m_pCommThread!=NULL)
{
pComPort->WaitCommEvent();
SetEvent(ComChangeEvent);
}
if(m_pProcessThread!=NULL)
SetEvent(ProcessChangeEvent);
return TRUE;
}
//删除设备
void CCommunication::DeleteTscCom(BYTE inPortNo)
{
int cSize,index;
CSingleLock commLock(&muxCommArray);
commLock.Lock(); //访问端口对象
cSize=m_aCom.GetSize();
for (index = 0; index < cSize; index++)
if (inPortNo == m_aCom[index]->m_ComPort)
break;
if(index >= cSize)
return;
CComPort * pComPort = m_aCom[index];
BYTE PortNo = pComPort->m_ComPort;
CString strPort;
strPort.Format("COM%d",PortNo);
AfxGetApp()->WriteProfileString("ComSetting",strPort,NULL);
//pComPort->DeleteAllDev();
//以下分别通知通信和处理线程
SetEvent(ComChangeEvent);
SetEvent(ProcessChangeEvent);
m_aReceiveEvent.RemoveAt(index+2);
m_aCom.RemoveAt(index);
m_aProcessEvent.RemoveAt(index+2);
if(pComPort->IsConnected)
pComPort->NotifyStatus(FALSE);
delete pComPort;
AfxGetMainWnd()->PostMessage(WM_COMMAND, IDM_DELETECOM, PortNo);
}
//创建通讯口数据接收线程,创建通讯口数据转发线程
BOOL CCommunication::Run()
{
if(!CreateThreadEvents())
return(FALSE);
//启动通讯口数据接收线程
StartComm();
//启动通讯口数据转发线程
StartProcData();
return TRUE;
}
// 通讯口数据接收线程开始
void CCommunication::StartComm()
{
m_pCommThread = new CComThrd();
if(m_pCommThread == NULL)
{
//MessageBox("pthread== NULL","",MB_OK);
return ;
}
// 调试版检查m_pCommThrd线程
ASSERT_VALID(m_pCommThread);
m_pCommThread->m_pThreadParams = NULL;
// 创建线程
if(!m_pCommThread->CreateThread(CREATE_SUSPENDED))
{
delete m_pCommThread;
m_pCommThread= NULL;
//MessageBox("Create m_pCommThread faile","",MB_OK);
return;
}
// 设置线程优先级 -》高一级
VERIFY(m_pCommThread->SetThreadPriority(THREAD_PRIORITY_NORMAL));
m_pCommThread->SetOwner(this);
for(int i=0;iWaitCommEvent();
m_pCommThread->ResumeThread();
}
// 表格处理线程开始
void CCommunication::StartProcData()
{
m_pProcessThread = new CProcDataThrd();
if(m_pCommThread == NULL)
{
//MessageBox("pthread== NULL","",MB_OK);
return ;
}
// 调试版检查通讯口数据转发线程
ASSERT_VALID(m_pProcessThread );
m_pProcessThread ->m_pThreadParams = NULL;
// 创建线程
if(!m_pProcessThread ->CreateThread(CREATE_SUSPENDED))
{
delete m_pProcessThread ;
m_pProcessThread = NULL;
//MessageBox("Create m_pProcessThread faile","",MB_OK);
return;
}
// 设置线程优先级 -》高一级
VERIFY(m_pProcessThread ->SetThreadPriority(THREAD_PRIORITY_NORMAL));
m_pProcessThread->SetOwner(this);
m_pProcessThread ->ResumeThread();
}
//串口查询
int CCommunication::FindComIndex(BYTE iDevNo)
{
int i;
CSingleLock commLock(&muxCommArray);//何时释放??
commLock.Lock(); //访问端口对象
for(i = 0;im_DeviceNo== iDevNo)
return i;
return -1;
}
//数据转发给串口设备
void CCommunication::ConvertToDevice(BYTE DeviceType, BYTE DeviceNo, BYTE *tabBuff, int tabCount)
{
// BYTE TmpBuff[m_MaxTableLen];
int i;
if(tabCount>m_MaxTableLen)//add logfile
return;
for(i=0;i=0)
if(m_aCom[ComIndex]->IsConnected)
m_aCom[ComIndex]->SendTable(TmpBuff,tabCount);
return;
}
//BroadCast DeviceNo
if(DeviceNo ==255)
{
for( i = 0 ;iIsConnected)
{
TmpBuff[6] = pComPort->GetMyDeviceNo();
pComPort->SendTable(TmpBuff,tabCount);
}
}
}
}
//发设备状态通知给中心
void CCommunication::SendNotifyAllDev()
{
int i;
CComPort *pComport;
for (i = 0; i < m_aCom.GetSize(); i++)
{
pComport = m_aCom[i];
m_pServerSocket->NotifyLineStatusTab(0,
pComport->GetMyDeviceNo(),pComport->IsConnected);
}
}
//判断设备是否超时
void CCommunication::AdjustDevConnect()
{
for(int i = 0; iAdjustDevConnect();
}
}
void CCommunication::TryToReadAllComm()
{
int i, length;
HANDLE hObjects[MaxWaitObjects];
DWORD dwObject;
BOOL bChangeCom;
bChangeCom=TRUE;
CSingleLock commLock(&muxCommArray);
hObjects[0]=hSetUser[0];
while (TRUE)
{
if(bChangeCom)
{
commLock.Lock();
length = m_aReceiveEvent.GetSize();
for(i=0;im_dwEventMask;
if (m_aCom[i-2]->m_dwEventMask & EV_RXCHAR) //数据到达
{
m_aCom[i-2]->ReadComData();
m_aCom[i-2]->WaitCommEvent();
}
break;
}
}
}
void CCommunication::ProcessCommData()
{
int i, length;
HANDLE hObjects[MaxWaitObjects];
DWORD dwObject;
BOOL bChangeCom;
bChangeCom=TRUE;
CSingleLock commLock(&muxCommArray);
hObjects[0]=hSetUser[1];
while (TRUE)
{
if(bChangeCom)
{
commLock.Lock();
length =m_aProcessEvent.GetSize();
for(i=0;iProcessTable();
break;
}
}
}
void CCommunication::StopAllRunningThread()
{
SetEvent(ExitEvent);
if (m_pCommThread != NULL)
::WaitForSingleObject(m_pCommThread->m_hThread, INFINITE);
if (m_pProcessThread != NULL)
::WaitForSingleObject(m_pProcessThread->m_hThread, INFINITE);
}
BOOL CCommunication::CreateThreadEvents()
{//创建线程的同步事件
if( m_aReceiveEvent.GetSize()>0 &&
m_aProcessEvent.GetSize()>0 )
return(TRUE); //只有第一此进入时才创建线程退出和端口打开关闭通知事件
if(NULL==(ExitEvent=::CreateEvent(NULL,TRUE,FALSE,NULL)))
return(FALSE); //创建退出通知事件
if(NULL==(ComChangeEvent=::CreateEvent(NULL,FALSE,FALSE,NULL)))
return(FALSE); //创建端口打开或关闭通知事件
if(NULL==(ProcessChangeEvent=::CreateEvent(NULL,FALSE,FALSE,NULL)))
return(FALSE); //创建端口打开或关闭通知事件
m_aReceiveEvent.Add(ExitEvent);
m_aProcessEvent.Add(ExitEvent);
m_aReceiveEvent.Add(ComChangeEvent);
m_aProcessEvent.Add(ProcessChangeEvent);
return(TRUE);
}
int CCommunication::GetComIndexByPort(BYTE iPortNo)
{
int i;
CSingleLock commLock(&muxCommArray);//何时释放??
commLock.Lock(); //访问端口对象
for(i = 0;im_ComPort== iPortNo)
return i;
return -1;
}
void CCommunication::SendCenter()
{
m_pServerSocket->SendCenter();
}
void CCommunication::Degrade()
{
TRACE("\nDegrade");
for(int i = 0; imUserMode.Mode==SimHand || pComPort->mUserMode.Mode==SpecifyStage || pComPort->mUserMode.Mode==AssignLampOffMode || pComPort->mUserMode.Mode==AssignYellowFlashMode)
{
pComPort->SendSelfControl();
}
}
}
void CCommunication::DegradeUserID(BYTE ID)
{
TRACE("\nDegradeUserID");
for(int i = 0; imUserMode.ID==ID)
if(pComPort->mUserMode.Mode==SimHand || pComPort->mUserMode.Mode==SpecifyStage || pComPort->mUserMode.Mode==AssignLampOffMode || pComPort->mUserMode.Mode==AssignYellowFlashMode)
{
pComPort->SendSelfControl();
}
}
}