repos_ecs/Device/modbusasc/modbusasc.cpp

// MGE.cpp : 定义 DLL 的初始化例程。
//

#include "stdafx.h"
#include "modbusasc.h"
#include "CommRS232.h"
#include "Head.h"
#include "winsock2.h"
#include "ProtocolModbus.h"
#include <stdlib.h>
#include ".\modbusasc.h"

#pragma   comment(lib,   "ws2_32.lib ")

vector<__COM_STRUCT> g_vtComStruct;
//vector<__BASIC_STRUCT> g_vtReadBasicInfo;

#ifdef _DEBUG
#define new DEBUG_NEW
#endif

BOOL InitComm( int nAddr, int nCommPort, int nRate, int nDataBit, int nStopBit, int nParity, int nInterval );
int CommDataCollect(int nCommPort, int nAddr, SETBASEPARAM SetBasePara, int nDataLen, char chMsg[80]);
int GetCommIndex( int nCommPort, int nAddr );

// CMGEApp

BEGIN_MESSAGE_MAP(CModbusascApp, CWinApp)
END_MESSAGE_MAP()


// CMGEApp 构造

CModbusascApp::CModbusascApp()
{
	// TODO: 在此处添加构造代码，
	// 将所有重要的初始化放置在 InitInstance 中

}


// 唯一的一个 CMGEApp 对象

CModbusascApp theApp;


// CMGEApp 初始化

BOOL CModbusascApp::InitInstance()
{
	CWinApp::InitInstance();

	return TRUE;
}

int CModbusascApp::ExitInstance()
{
	// TODO: 在此添加专用代码和/或调用基类

	// 关闭已经打开的串口
	for( unsigned int i = 0; i < g_vtComStruct.size(); i++ )
	{
		if( g_vtComStruct[i].pComm )
		{
			delete g_vtComStruct[i].pComm;
			g_vtComStruct[i].pComm = NULL;
		}
	}

	return CWinApp::ExitInstance();
}

int ASC_DLLInit( int nCommPort, int nAddr, SETBASEPARAM SetBasePara, int nDataLen, char chMsg[80] )
{
	return CommDataCollect(nCommPort, nAddr, SetBasePara, nDataLen, chMsg);
}

void ASC_DLLUnInit()
{
	// 关闭串口，放到退出Dll时去关闭 ExitInstance
	return;
}

//初始化串口
BOOL ASC_DLLInitCom( int nAddr, int nCommPort, int nRate, int nDataBit, int nStopBit, int nParity, int nInterval)
{
	if (InitComm( nAddr, nCommPort, nRate, nDataBit, nStopBit, nParity, nInterval ))
	{
		//LOG4C((LOG_NOTICE, "ASC_DLLInitCom return true"));
		return TRUE;
	}
	else
	{
		//LOG4C((LOG_NOTICE, "ASC_DLLInitCom return false"));
		return FALSE;
	}
}

BOOL InitComm( int nAddr, int nCommPort, int nRate, int nDataBit, int nStopBit, int nParity, int nInterval )
{
	CCommAsyn *pComm = NULL;
	int nCommIndex = GetCommIndex( nCommPort, nAddr );
	if( nCommIndex == -1 )
	{
		pComm = new CCommRS232;
		PORTPARAM portParam; 
		portParam.StartAddr = nAddr;		//起止地址	
		portParam.PortNo = nCommPort;		//Com端口
		portParam.BaudRate = nRate;		//波特率
		portParam.ByteSize = nDataBit;	// Number of bits/byte, 4-8       
		portParam.StopBits = nStopBit;	/* 结束位 0,1,2 = 1, 1.5, 2               */
		portParam.Parity = nParity;		/* 校验位 0-4=None,Odd,Even,Mark,Space    */
		portParam.Interval = nInterval;	//间隔时间
		if(!pComm->InitParam(&portParam))
		{
			delete pComm;
			pComm = NULL;
			return FALSE;
		}
		else
		{
			COM_STRUCT tagComStruct;
			tagComStruct.nAddr = nAddr;
			tagComStruct.nCommPort = nCommPort;
			tagComStruct.pComm = pComm;

			// 串口只打开一次且按顺序打开，不存在资源共享冲突，所以不用加保护 
			g_vtComStruct.push_back( tagComStruct );
		}
	}

	return TRUE;
}

int ASC_DLLRequestStatusData(int nCommPort, int nAddr, int nByteNum, char *pData)
{
	int nCommIndex = GetCommIndex( nCommPort, nAddr );
	if( nCommIndex == -1 ) return ERR_CODE_MODBUS_ASC_COM_FAULT;
	CCommAsyn *pComm = NULL;
	pComm = g_vtComStruct[nCommIndex].pComm;

	char DataLen[2] = {0};
	DataLen[0] = pComm->m_pProtocol->m_structResponse.StatusStruct.RtnByteNum[0];
	DataLen[1] = pComm->m_pProtocol->m_structResponse.StatusStruct.RtnByteNum[1];
	nByteNum = atoi((const char*)DataLen);

	if( nByteNum == 0 )		// 设备没有请求到数据
	{
		return ERR_CODE_MODBUS_ASC_COM_READ_NO_DATA;
	}

	int i = 0;
	int nNum = 2 * nByteNum;

	while( i < nNum )
	{
		pData[i] = pComm->m_pProtocol->m_structResponse.StrRtnMsg[i];
		i++;
	}

	return 0;
}


int ASC_DLLRequestWrStatusData(int nCommPort, int nAddr, char *pData)
{
	int nCommIndex = GetCommIndex( nCommPort, nAddr );
	if( nCommIndex == -1 ) return ERR_CODE_MODBUS_ASC_COM_FAULT;
	CCommAsyn *pComm = NULL;
	pComm = g_vtComStruct[nCommIndex].pComm;

	char DataLen[4] = {0};
	DataLen[0] = pComm->m_pProtocol->m_RequestWrParam.RequestRegNum[0];
	DataLen[1] = pComm->m_pProtocol->m_RequestWrParam.RequestRegNum[1];
	DataLen[2] = pComm->m_pProtocol->m_RequestWrParam.RequestRegNum[2];
	DataLen[3] = pComm->m_pProtocol->m_RequestWrParam.RequestRegNum[3];

	int nByteNum = atoi((const char*)DataLen);
	
	if( nByteNum == 0 )		// 设备没有请求到数据
	{
		return ERR_CODE_MODBUS_ASC_COM_READ_NO_DATA;
	}

	int i = 0;
	int nNum = 4 * nByteNum;
	while( i < nNum )
	{
		pData[i] = pComm->m_pProtocol->m_RequestWrParam.Data[i];
		i++;
	}

	return 0;
}


int ASC_DLLWrCom(int nCommPort, int nAddr, SETBASEPARAM SetBasePara, double Data, int nDataLen)
{
//	int iResult = g_pComm-> WriteCommand(SetBasePara, Data);
//	if (iResult == 0)
//		return TRUE;
//	else
//		return FALSE;

	int nCommIndex = GetCommIndex( nCommPort, nAddr );
	if( nCommIndex == -1 ) return ERR_CODE_MODBUS_ASC_COM_FAULT;

	CCommAsyn *pComm = NULL;
	pComm = g_vtComStruct[nCommIndex].pComm;
	int iResult = pComm->WriteCommand(SetBasePara, Data, nDataLen);
	return iResult;
}


void ASC_DLLDetectOnlineCallBack()
{
	;
}

int CommDataCollect(int nCommPort, int nAddr, SETBASEPARAM SetBasePara, int nDataLen, char chMsg[80])
{
	int nCommIndex = GetCommIndex( nCommPort, nAddr );
	if( nCommIndex == -1 ) return ERR_CODE_MODBUS_ASC_COM_FAULT;

	CCommAsyn *pComm = NULL;
	pComm = g_vtComStruct[nCommIndex].pComm;
	return pComm->WorkMain(SetBasePara, nDataLen, chMsg);
}

int GetCommIndex( int nCommPort, int nAddr )
{
	for( int i = 0; i < (int)g_vtComStruct.size(); i++ )
	{
		if( g_vtComStruct[i].nCommPort == nCommPort)// && g_vtComStruct[i].nAddr == nAddr)
		{
			return i;
		}
	}

	return -1;
}