remoapi.cpp

串口传输数据库函数

#include "stdafx.h"
#include <windows.h>
#include <stdlib.h>
#include <conio.h>
#include <string.h>
#include "global.h"
#include "SerialPort.h"
#include "RemCom_rtu.h"

#ifdef _WIN32_WCE  //Provided for WinCon
	#include "UARTCE.h"
	#include "I7000CE.h"

	#define strnset _strnset
#else
	#ifdef __cplusplus
		#define EXPORTS extern "C" __declspec(dllexport)
	#else
		#define EXPORTS __declspec(dllexport)
	#endif

//	#include "uart.h"
	#include "RemoAPI.h"
#endif


CRemCom_rtuApp theApp;
unsigned char CRCHi,CRCLo;
//hEvent = CreateEvent(0,FALSE,FALSE,"CanReceive");
////校验和函数

static unsigned char CRC16Hi[] = {
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40
} ;

/* CRC16 Table Low byte */
static char CRC16Lo[] = {
0x00, 0xC0, 0xC1, 0x01, 0xC3, 0x03, 0x02, 0xC2,
0xC6, 0x06, 0x07, 0xC7, 0x05, 0xC5, 0xC4, 0x04,
0xCC, 0x0C, 0x0D, 0xCD, 0x0F, 0xCF, 0xCE, 0x0E,
0x0A, 0xCA, 0xCB, 0x0B, 0xC9, 0x09, 0x08, 0xC8,
0xD8, 0x18, 0x19, 0xD9, 0x1B, 0xDB, 0xDA, 0x1A,
0x1E, 0xDE, 0xDF, 0x1F, 0xDD, 0x1D, 0x1C, 0xDC,
0x14, 0xD4, 0xD5, 0x15, 0xD7, 0x17, 0x16, 0xD6,
0xD2, 0x12, 0x13, 0xD3, 0x11, 0xD1, 0xD0, 0x10,
0xF0, 0x30, 0x31, 0xF1, 0x33, 0xF3, 0xF2, 0x32,
0x36, 0xF6, 0xF7, 0x37, 0xF5, 0x35, 0x34, 0xF4,
0x3C, 0xFC, 0xFD, 0x3D, 0xFF, 0x3F, 0x3E, 0xFE,
0xFA, 0x3A, 0x3B, 0xFB, 0x39, 0xF9, 0xF8, 0x38,
0x28, 0xE8, 0xE9, 0x29, 0xEB, 0x2B, 0x2A, 0xEA,
0xEE, 0x2E, 0x2F, 0xEF, 0x2D, 0xED, 0xEC, 0x2C,
0xE4, 0x24, 0x25, 0xE5, 0x27, 0xE7, 0xE6, 0x26,
0x22, 0xE2, 0xE3, 0x23, 0xE1, 0x21, 0x20, 0xE0,
0xA0, 0x60, 0x61, 0xA1, 0x63, 0xA3, 0xA2, 0x62,
0x66, 0xA6, 0xA7, 0x67, 0xA5, 0x65, 0x64, 0xA4,
0x6C, 0xAC, 0xAD, 0x6D, 0xAF, 0x6F, 0x6E, 0xAE,
0xAA, 0x6A, 0x6B, 0xAB, 0x69, 0xA9, 0xA8, 0x68,
0x78, 0xB8, 0xB9, 0x79, 0xBB, 0x7B, 0x7A, 0xBA,
0xBE, 0x7E, 0x7F, 0xBF, 0x7D, 0xBD, 0xBC, 0x7C,
0xB4, 0x74, 0x75, 0xB5, 0x77, 0xB7, 0xB6, 0x76,
0x72, 0xB2, 0xB3, 0x73, 0xB1, 0x71, 0x70, 0xB0,
0x50, 0x90, 0x91, 0x51, 0x93, 0x53, 0x52, 0x92,
0x96, 0x56, 0x57, 0x97, 0x55, 0x95, 0x94, 0x54,
0x9C, 0x5C, 0x5D, 0x9D, 0x5F, 0x9F, 0x9E, 0x5E,
0x5A, 0x9A, 0x9B, 0x5B, 0x99, 0x59, 0x58, 0x98,
0x88, 0x48, 0x49, 0x89, 0x4B, 0x8B, 0x8A, 0x4A,
0x4E, 0x8E, 0x8F, 0x4F, 0x8D, 0x4D, 0x4C, 0x8C,
0x44, 0x84, 0x85, 0x45, 0x87, 0x47, 0x46, 0x86,
0x82, 0x42, 0x43, 0x83, 0x41, 0x81, 0x80, 0x40
} ;

//unsigned char CRCHi ; /* high byte of CRC initialized */
//unsigned char CRCLo ; /* low byte of CRC initialized */

unsigned GetCRC16(unsigned char *puchMsg, int DataLen)
{
  unsigned Index ; /* will index into CRC16 lookup table */

  CRCHi = 0xFF ; /* high byte of CRC16 initialized */
  CRCLo = 0xFF ; /* low byte of CRC16 initialized */
  while (DataLen--){
    Index = CRCHi ^ *puchMsg++ ; /* calculate the CRC16 */
    CRCHi = CRCLo ^ CRC16Hi[Index] ;
    CRCLo = CRC16Lo[Index] ;
  }
  return ((unsigned)CRCHi << 8 | CRCLo) ;
}

WORD CALLBACK Get_RemCom_Version(void)
{
	return 1;
}

BOOL  CALLBACK Open_ComRtu(unsigned char cPort,int timeout, DWORD dwBaudrate, char cData, char cParity, char cStop)
{   
	//CSerialPort m_NewCom;
	//m_ComX.InitPort(this,m_PortNumber,Rate,'N',8,1,9,512);
	//InitPort(CWnd* pPortOwner,UINT portnr,
	//	                   UINT baud,char parity,UINT databits,
	//			           UINT stopsbits,DWORD dwCommEvents,
	//			            UINT nBufferSize)
	//m_ComX.InitPort(this,m_PortNumber,Rate,'N',8,1,9,512);
/* cPort:		1~255                                            */
/* dwBaudrate:	150,300,600,1200,2400,4800,9600,19200,38400,     */
/*				57600,115200,230400,460800,921600                */
/* cData:		5,6,7,8                                          */
/* cParity:		0 ==> Non Parity	(NonParity)                  */
/*				1 ==> Odd Parity	(OddParity)                  */
/*				2 ==> Even Parity	(EvenParity)                 */
/* cStop		0 ==> 1 Stop Bit	(OneStopBit)                 */
/*				1 ==> 1.5 Stop Bit	(One5StopBit)                */
/*				2 ==> 2 Stop Bit	(TwoStopBit)                 */
	BOOL m_Ret0,m_Ret1,m_Ret;
	char m_partity,m_stopsbits;
	if(cParity == 0)
	{
		m_partity = 'N';
	}

	if(cParity == 1)
	{
		m_partity = 'E';
	}

	if(cParity == 2)
	{
		m_partity = 'O';
	}
//	if(cStop)
	if (cPort >=1 && cPort <=255) //串口1
	{
		m_Ret0 = (theApp.m_Com).InitPort((CWnd*)(&theApp),cPort,dwBaudrate,m_partity,(int)cData,(int)cStop,9,512);
		m_Ret1 = (theApp.m_Com).StartMonitoring();
		Sleep(100);
   
		m_Ret = m_Ret0 && m_Ret1; 
		if(m_Ret == TRUE)
		{
    		hEventResult[0] = CreateEvent(NULL, TRUE, FALSE, NULL);//创建事件,接收数据时起作用
    		hEventResult[1] = CreateEvent(NULL, TRUE, FALSE, NULL);//创建事件,接收数据时起作用
			//SetEvent(hEventResult[0]);//初始化
			//SetEvent(hEventResult[1]);//初始化
			return TRUE;
		}
		else
		{
			if(m_Ret1==TRUE)
			{
				(theApp.m_Com).StopMonitoring();
			}
			return FALSE;
		}
	}
    else
	{
		return FALSE;
	}
}

BOOL  CALLBACK Close_ComRtu(unsigned char cPort)
{
	BOOL m_Ret;
	if(cPort >=1 && cPort<= 255)   //串口1
	{

	    if(	(theApp.m_Com).m_hComm == 0)
			return TRUE;

		m_Ret = (theApp.m_Com).StopMonitoring();
////////////////
		while((theApp.m_Com).m_stopflag)  //等待结束
		{;}
////////////////

		(theApp.m_Com).Close();
	    return m_Ret;
	}
   else
	{
		return FALSE;
	}
}

WORD CALLBACK Change_Baudrate(unsigned char cPort, DWORD dwBaudrate)
{
	return 0;
}

WORD CALLBACK Change_Config(unsigned char cPort, DWORD dwBaudrate, char cData, char cParity, char cStop)
{
		Close_ComRtu(cPort);
		Sleep(100);
//		Open_Com(cPort,dwBaudrate,cData,cParity,cStop);
	return 0;
}

BOOL  CALLBACK Send_Receive_Rtu(unsigned char cPort, char szCmd[], int writelen,char
        szResult[], WORD wTimeOut, WORD wChksum, WORD *wT)
{
/* cPort:		1~255																	 */
/* szCmd[]:		1024 Bytes maximum, without zero (0x0D) character.						 */
/* szResult[]:	1024 Bytes maximum, with one zero or 0x0D terminal character.			 */
/* wTimeOut:	Timeout for receiving result string. 									 */
/*				Unit: ms (1/1000 second)												 */
/* wChksum:		0   ==> add one 0x0D byte to the end of the szCmd						 */
/*				<>0 ==> add two check sum bytes and one 0x0D byte to the end of the szCmd*/
/* *wT			return a reference number for identify the performance. 				 */
/*				*wT --> 0 :good 	*/
//			m_ComX.WriteToPort("$00M\r"); //启动查询
	DWORD mEvent = 0;
	BOOL mFlag;
	mFlag = TRUE;
	int j ;
	int q;
	char m_temp1[150];
	char *m_temp;
	m_temp = &(m_temp1[0]);
	memset(result,0,3000);
	resultlength = 0;
//	char m_temp[150];
	CString m_WriteStr,m_Command;            //最终的命令
	CString m_WriteStr1;
	m_WriteStr = "";
    m_WriteStr.Format("%s",szCmd);
	char cTem[50];
	for (int i=0;i<writelen;i++)
		cTem[i] = szCmd[i];

	(theApp.m_Com).i_timeout = (int)wTimeOut;

    if(cPort >= 1 && cPort <=255)
	{
//		if (wChksum == 0)  //无校验
//		{
//			m_Command =m_WriteStr + "\r";
			(theApp.m_Com).WriteToPort(cTem, writelen);//(LPSTR)(LPCTSTR)m_WriteStr);  //写命令
//		}
//		if (wChksum == 1)  //有校验
//		{
//			m_WriteStr1 = m_WriteStr + "\r";
//			m_Command =m_WriteStr + theApp.AddCheckSum(m_WriteStr1) + "\r";
//			(theApp.m_Com).WriteToPort((LPSTR)(LPCTSTR)m_Command);  //写命令
//		}
			 //清空
			Sleep(10);
		    mEvent = WaitForMultipleObjects(2, hEventResult, FALSE, INFINITE);
			
			switch(mEvent)
			{
			case 0:
			//	szResult = (LPSTR)(LPCTSTR)(m_Result);
				
				m_temp =(LPSTR)(LPCTSTR)(m_Result);  //放到结果串中
/////////////////////////
				for(j = 0;j<=resultlength;j++)
				{	
					szResult[j] = result[j];
				}

				ResetEvent(hEventResult[1]);   //重新复位
				StartFlag = FALSE;
//				mFlag = FALSE;
				break;
			case 1:
//				szResult = (LPSTR)(LPCTSTR)(m_Result);
				int i_getnum;

				ResetEvent(hEventResult[1]);   //重新复位
				StartFlag = FALSE;
				
				i_getnum = resultlength;

				if(i_getnum <=0)
				{
					mFlag = FALSE;
					break;
				}
				m_temp =(LPSTR)(LPCTSTR)(m_Result);  //放到结果串中

				for(j = 0;j<=i_getnum;j++)
				{
					szResult[j] = result[j];
				}
//				szResult[resultlength] = 0x0;
				break;
			default :  break;							
		
			}
//			delete m_temp;
			if(mFlag == TRUE)
			{
				*wT = resultlength;    //结果无错误
//				delete m_temp;
				return TRUE;
			}
			else
			{
				*wT = 0;    //结果有错误 
//				delete m_temp;
				return FALSE ;
				
			}
	}
//	}
//	delete  m_temp;
	return FALSE;
}

BOOL CALLBACK GetRtuStrCRC(unsigned  char * source, int length,unsigned char * dest)
{
	unsigned int crc;
	crc = GetCRC16(source, length);
	for(int i=0;i<length;i++)
	{
		dest[i] = source[i];
	}
	dest[length] = ( crc>>8 ) & 0xff;
	dest[length+1] = crc & 0xff;

	return TRUE;
}