repos_ecs/源数据/PC环境监控/tryto v1.0.0.3/MFCService/Service/greeprocess.cpp

#include "stdafx.h"
#include "greeprocess.h"
#include "Global.h"
#include "struct.h"
#include "NoticeQueue.h"

HANDLE	g_GREERequestThread = NULL;
HANDLE	g_GREEResponseThread = NULL;
DWORD g_dwGreeVariantTick = 0;
CRITICAL_SECTION g_csGreeReadOneData;

//GREE动态库输出函数
HINSTANCE g_hGREELibModule = NULL;
GREE_DLLInitCom pGREE_DLLInitCom = NULL;
GREE_DLLInit pGREE_DLLInit = NULL;
GREE_DLLUnInit pGREE_DLLUnInit = NULL;
GREE_DLLWrCom pGREE_DLLWrCom = NULL;

void UnInitGreeDll();
int GetGreeFromIni(char chCmd[32], char *pPosBegin);


int GetGreeFromIni(char chCmd[32], char *pPosBegin)
{
	CHAR strFile[MAX_FILE_LENGTH + 1] = "";
	CHAR strValue[8] = "";
	wsprintf(strFile, "%s\\config\\gree.ini", g_strDirectory);
	//Database
	GetPrivateProfileString(chCmd, "PosIndex", "", strValue, sizeof(strValue), strFile);
	memcpy(pPosBegin, strValue, strlen(strValue));

	return 0;
}

BOOL LoadGreeDll(CString strpath)
{
	char strFile[256] = {0};
	g_hGREELibModule = NULL;
	sprintf(strFile, "%s\\dll\\gree.dll", strpath);

	InitializeCriticalSection( &g_csGreeReadOneData );
	g_hGREELibModule = AfxLoadLibrary(strFile);

	//GREE 动态库初始化
	if (NULL != g_hGREELibModule)
	{
		pGREE_DLLInitCom =( GREE_DLLInitCom)::GetProcAddress(g_hGREELibModule, "GREE_DLLInitCom"); 
		pGREE_DLLInit = (GREE_DLLInit)::GetProcAddress(g_hGREELibModule, "GREE_DLLInit");
		pGREE_DLLUnInit = (GREE_DLLUnInit)::GetProcAddress(g_hGREELibModule, "GREE_DLLUnInit");
		pGREE_DLLWrCom = (GREE_DLLWrCom)::GetProcAddress(g_hGREELibModule, "GREE_DLLWrCom");
		return TRUE;
	}
	else
	{
		return FALSE;
	}
}

BOOL InitGreeComm(int iAddr, int iPort, int iBaudrate, int iDataBit, int iStopBit, int iParity, int iIntervals)
{
	if (pGREE_DLLInitCom(iAddr,iPort, iBaudrate, iDataBit, iStopBit, iParity, iIntervals))//初始化串口
		return TRUE;
	else
		return FALSE;
}

int	GreeRequestData(	SETBASEPARAM SetBasePara,
	int nDataLen,
	int nPort,
	int nDevAddr,
	char chDevUid[20], 
	int iVarID,
	char chRs232cmd[32])
{
	char chMsg[80] = {0};
	int nReadPos = 0;
	char pPosBegin[8]={0};
	GetGreeFromIni(chRs232cmd, pPosBegin);
	nReadPos = atoi(pPosBegin);
	int nRet = pGREE_DLLInit(nPort, nDevAddr, nDataLen, nReadPos,chMsg);
	if(nRet==0)
	{
		nRet = GreeSingleResponseData(chDevUid, iVarID, chMsg );
	}

	return nRet;
}

int GreeSingleResponseData(char chDevUid[20], int iVarID, char chMsg[80])
{
	int nDeviceIndex = -1, nVarIndex = -1;
	BOOL bFind = FindVar(chDevUid, iVarID, nDeviceIndex, nVarIndex);
	if( bFind == FALSE ) return -1;

	CDevice *pDev = g_pDevicesManager->m_Devices[nDeviceIndex];
	CBaseVar *pBaseVar = pDev->m_Vars[nVarIndex];

	EnterCriticalSection(&g_csGreeReadOneData);
	pDev->m_dwOnlineTick = GetTickCount();
	LeaveCriticalSection(&g_csGreeReadOneData);
	
	int nVarItemID = pBaseVar->m_nVarItemID;
	int nDataLen = pBaseVar->m_iDataLen;
	int nValue;
	double fCoef = pBaseVar->m_dbCoefficient;

	if( nVarItemID > 0 )//BIT位变量
	{
		int nStartBit = pBaseVar->m_nStartBit;
		int nEndBit = pBaseVar->m_nEndBit;
		char szValue[4];
		// Gree空调特殊处理
		char chBuffer[8] = {0};
		memset(chBuffer, 0, sizeof(chBuffer));
		BYTE byValue = chMsg[0];
		DigitToBinary(byValue, chBuffer, 8) ;

		CString strTemp;
		switch( nEndBit - nStartBit )
		{
		case 0:
			strTemp.Format("%c", chBuffer[nStartBit]);
			nValue = atoi(strTemp);
			break;
		case 1:
			strTemp.Format("00%c%c", chBuffer[nStartBit + 1], chBuffer[nStartBit]);
			szValue[0] = AsciiToBYTE( strTemp.GetAt(0) );
			szValue[1] = AsciiToBYTE( strTemp.GetAt(1) );
			szValue[2] = AsciiToBYTE( strTemp.GetAt(2) );
			szValue[3] = AsciiToBYTE( strTemp.GetAt(3) );
			nValue = Hex16(szValue);
			break;
		case 2:
			strTemp.Format("0%c%c%c", chBuffer[nStartBit + 2], chBuffer[nStartBit + 1], chBuffer[nStartBit]);
			szValue[0] = AsciiToBYTE( strTemp.GetAt(0) );
			szValue[1] = AsciiToBYTE( strTemp.GetAt(1) );
			szValue[2] = AsciiToBYTE( strTemp.GetAt(2) );
			szValue[3] = AsciiToBYTE( strTemp.GetAt(3) );
			nValue = Hex16(szValue);
			break;
		case 3:
			strTemp.Format("%c%c%c%c", chBuffer[nStartBit + 2], chBuffer[nStartBit + 1], chBuffer[nStartBit], chBuffer[nStartBit +3]);

			szValue[0] = AsciiToBYTE( strTemp.GetAt(0) );
			szValue[1] = AsciiToBYTE( strTemp.GetAt(1) );
			szValue[2] = AsciiToBYTE( strTemp.GetAt(2) );
			szValue[3] = AsciiToBYTE( strTemp.GetAt(3) );
			nValue = Hex16(szValue);
			break;
		}
		//strTemp.Format("%d", 

		EnterCriticalSection( &g_csGreeReadOneData );
		pBaseVar->m_dbData = (double)(nValue * fCoef);
		if( pBaseVar->m_nRearm != 0 )
		{
			pBaseVar->m_dbData = pBaseVar->m_dbData + pBaseVar->m_nRearm;
		}
		LeaveCriticalSection( &g_csGreeReadOneData );
		//TRACE2("变量ID%d, 值=%d\r\n", iVarID, nValue);
	}
	else
	{
		// 联合类型变量做特殊处理
		if( pBaseVar->m_nVarTypeID >= UNION_TYPE_MIN_ID && pBaseVar->m_nVarTypeID <= UNION_TYPE_MAX_ID )
		{
			if( nDataLen == 2 )
			{
				//int类型
				union  __UNION_VAR_INT{
					char   ch[2];   
					int	   value;   
				}unionVarInt;
	            
				unionVarInt.ch[0] = chMsg[1];
				unionVarInt.ch[1] = chMsg[0];

				EnterCriticalSection( &g_csGreeReadOneData );
				pBaseVar->m_dbData = (double)(unionVarInt.value * fCoef);
				if( pBaseVar->m_nRearm != 0 )
				{
					pBaseVar->m_dbData = pBaseVar->m_dbData + pBaseVar->m_nRearm;
				}
				LeaveCriticalSection( &g_csGreeReadOneData );

				//TRACE2("联合类型变量ID%d, 值=%d\r\n", iVarID, unionVarInt.value);
			}
			else if( nDataLen == 4  )
			{
				//float类型
				union __UNION_VAR_FLOAT{
					char ch[4];
					float value;
				}unionVarFloat;

				unionVarFloat.ch[0] = chMsg[3];
				unionVarFloat.ch[1] = chMsg[2];
				unionVarFloat.ch[2] = chMsg[1];
				unionVarFloat.ch[3] = chMsg[0];
				
				EnterCriticalSection( &g_csGreeReadOneData );
				pBaseVar->m_dbData = (double)(unionVarFloat.value * fCoef);
				if( pBaseVar->m_nRearm != 0 )
				{
					pBaseVar->m_dbData = pBaseVar->m_dbData + pBaseVar->m_nRearm;
				}
				LeaveCriticalSection( &g_csGreeReadOneData );
				//TRACE2("联合类型变量ID%d, 值=%.1f\r\n", iVarID, unionVarFloat.value);
			}
			else if( nDataLen == 8 )
			{
				//double类型
				union __UNION_VAR_DOUBLE{
					char ch[8];
					double value;
				}unionVarDouble;


				unionVarDouble.ch[0] = chMsg[7];
				unionVarDouble.ch[1] = chMsg[6];
				unionVarDouble.ch[2] = chMsg[5];
				unionVarDouble.ch[3] = chMsg[4];
				unionVarDouble.ch[4] = chMsg[3];
				unionVarDouble.ch[5] = chMsg[2];
				unionVarDouble.ch[6] = chMsg[1];
				unionVarDouble.ch[7] = chMsg[0];

				EnterCriticalSection( &g_csGreeReadOneData );
				pBaseVar->m_dbData = (double)(unionVarDouble.value * fCoef);
				if( pBaseVar->m_nRearm != 0 )
				{
					pBaseVar->m_dbData = pBaseVar->m_dbData + pBaseVar->m_nRearm;
				}
				LeaveCriticalSection( &g_csGreeReadOneData );
				//TRACE2("联合类型变量ID%d, 值=%.1f\r\n", iVarID, unionVarDouble.value);
			}
		}
		else
		{
			CString strTemp;
			switch( nDataLen )
			{
			case 1:
				nValue = chMsg[0];
				break;
			case 2:
				//short int wdValue;
				strTemp.Format("%d%d", chMsg[0] - '0', chMsg[1] - '0');
				nValue = atoi(strTemp);
				//memcpy(&wdValue, chMsg, sizeof(short int));
				//nValue = ntohs(wdValue);
				//nValue = wdValue;
				break;
			case 3:			// 一般为字符串类型，不作处理
				
				break;
			case 4:			// 保留，暂时不知道什么处理
				
				break;
			case 5:			// 一般为字符串类型，不作处理
				
				break;
			case 6:			// 一般为字符串类型，不作处理
				
				break;
			case 7:			// 一般为字符串类型，不作处理
				
				break;
			case 8:			// 保留，暂时没有用到
				
				break;
			}

			EnterCriticalSection( &g_csGreeReadOneData );
			if( pBaseVar->m_nMaxValues != 0 || pBaseVar->m_nMinValues != 0 ||
				pBaseVar->m_nMaxConvtRate != 0 || pBaseVar->m_nMinConvtRate != 0 )
			{
				double fScale = 1.0;
				if( pBaseVar->m_nMaxValues - pBaseVar->m_nMinValues > 0 )
				{
					fScale = (double)(pBaseVar->m_nMaxConvtRate - pBaseVar->m_nMinConvtRate) / 
					(double)(pBaseVar->m_nMaxValues - pBaseVar->m_nMinValues);
				}

				pBaseVar->m_dbData = nValue * 
					fCoef * 
					fScale;
			}
			else
			{
				pBaseVar->m_dbData = (double)(nValue * fCoef);
			}

			if( pBaseVar->m_nRearm != 0 )
			{
				pBaseVar->m_dbData = pBaseVar->m_dbData + pBaseVar->m_nRearm;
			}

			//g_RtuReadOneData.dbData = (double)(nValue * fCoef);
			LeaveCriticalSection( &g_csGreeReadOneData );
			//TRACE2("普通变量ID%d, 值=%f\r\n", iVarID, g_RtuReadOneData.dbData);
		}
	}
	 
	EnterCriticalSection(&g_csGreeReadOneData);
	pDev->m_dwOnlineTick = GetTickCount();
	LeaveCriticalSection(&g_csGreeReadOneData);

	return 0;
}

int RequestGreeWrData(char chDevUid[20], int iVarID, double data, char chRs232cmd[32])//用于请求写命令操作
{
	int nDeviceIndex = -1, nVarIndex = -1;
	BOOL bFind = FindVar(chDevUid, iVarID, nDeviceIndex, nVarIndex);
	if( bFind == FALSE ) return -1;

	CDevice *pDev = g_pDevicesManager->m_Devices[nDeviceIndex];
	CBaseVar *pBaseVar = pDev->m_Vars[nVarIndex];

	int nWorkStatus, nWorkMode = 0, nFanSpeed = 0;
	int nPutWind = 1, nAirTrade, nSleep, nLight; 
	int nTempSetPoint;

	CHAR strFile[MAX_FILE_LENGTH + 1] = "";
	CHAR strValue[MAX_VALUE_LENGTH + 1] = "";

	wsprintf(strFile, "%s\\config\\Gree.ini", g_strDirectory);

	nAirTrade = GetPrivateProfileInt(chRs232cmd, "AirTrade", 0, strFile);
	nSleep = GetPrivateProfileInt(chRs232cmd, "Sleep", 0, strFile);
	nLight = GetPrivateProfileInt(chRs232cmd, "Light", 0, strFile);
	nTempSetPoint = GetPrivateProfileInt("Other", "SetCoolTemp", 0, strFile);

	nWorkStatus = 1;

	if( strcmp( chRs232cmd, "cmd-7" ) == 0 )
	{
		nWorkStatus = 0;
	}
	else if( strcmp(chRs232cmd, "cmd-8") == 0 )				//开机(模式：自动,风量：自动)
	{
		nWorkMode = 0;
		nFanSpeed = 0;
	}
	else if( strcmp(chRs232cmd, "cmd-9") == 0 )			//开机(模式：制冷,风量：自动)
	{
		nWorkMode = 1; 
		nFanSpeed = 0;
	}
	else if( strcmp(chRs232cmd, "cmd-10") == 0 )		//开机(模式：抽湿,风量：自动)
	{
		nWorkMode = 2;
		nFanSpeed = 0;
	}
	else if( strcmp(chRs232cmd, "cmd-11") == 0 )		//开机(模式：送风,风量：自动)
	{
		nWorkMode = 3;
		nFanSpeed = 0;
	}
	else if( strcmp(chRs232cmd, "cmd-12") == 0 )		//开机(模式：制热,风量：自动)
	{
		nWorkMode = 4;
		nFanSpeed = 0;
		nTempSetPoint = GetPrivateProfileInt("Other", "SetHeartTemp", 0, strFile);
	}
	else if( strcmp(chRs232cmd, "cmd-13") == 0 )		//开机(模式：自动,风量：低风)
	{
		nWorkMode = 0;
		nFanSpeed = 1;
	}
	else if( strcmp(chRs232cmd, "cmd-14") == 0 )		//开机(模式：制冷,风量：低风)
	{
		nWorkMode = 1;
		nFanSpeed = 1;
	}
	else if( strcmp(chRs232cmd, "cmd-15") == 0 )		//开机(模式：抽湿,风量：低风)
	{
		nWorkMode = 2;
		nFanSpeed = 1;
	}
	else if( strcmp(chRs232cmd, "cmd-16") == 0 )		//开机(模式：送风,风量：低风)
	{
		nWorkMode = 3;
		nFanSpeed = 1;
	}
	else if( strcmp(chRs232cmd, "cmd-17") == 0 )		//开机(模式：制热,风量：低风)
	{
		nWorkMode = 4;
		nFanSpeed = 1;
		nTempSetPoint = GetPrivateProfileInt("Other", "SetHeartTemp", 0, strFile);
	}
	else if( strcmp(chRs232cmd, "cmd-18") == 0 )		//开机(模式：自动,风量：中风)
	{
		nWorkMode = 0;
		nFanSpeed = 2;
	}
	else if( strcmp(chRs232cmd, "cmd-19") == 0 )		//开机(模式：制冷,风量：中风)
	{
		nWorkMode = 1;
		nFanSpeed = 2;
	}
	else if( strcmp(chRs232cmd, "cmd-20") == 0 )		//开机(模式：抽湿,风量：中风)
	{
		nWorkMode = 2;
		nFanSpeed = 2;
	}
	else if( strcmp(chRs232cmd, "cmd-21") == 0 )		//开机(模式：送风,风量：中风)
	{
		nWorkMode = 3;
		nFanSpeed = 2;
	}
	else if( strcmp(chRs232cmd, "cmd-22") == 0 )		//开机(模式：制热,风量：中风)
	{
		nWorkMode = 4;
		nFanSpeed = 2;
		nTempSetPoint = GetPrivateProfileInt("Other", "SetHeartTemp", 0, strFile);
	}
	else if( strcmp(chRs232cmd, "cmd-23") == 0 )		//开机(模式：自动,风量：高风)
	{
		nWorkMode = 0;
		nFanSpeed = 3;
	}
	else if( strcmp(chRs232cmd, "cmd-24") == 0 )		//开机(模式：制冷,风量：高风)
	{
		nWorkMode = 1;
		nFanSpeed = 3;
	}
	else if( strcmp(chRs232cmd, "cmd-25") == 0 )		//开机(模式：抽湿,风量：高风)
	{
		nWorkMode = 2;
		nFanSpeed = 3;
	}
	else if( strcmp(chRs232cmd, "cmd-26") == 0 )		//开机(模式：送风,风量：高风)
	{
		nWorkMode = 3;
		nFanSpeed = 3;
	}
	else if( strcmp(chRs232cmd, "cmd-27") == 0 )		//开机(模式：制热,风量：高风)
	{
		nWorkMode = 4;
		nFanSpeed = 3;
		nTempSetPoint = GetPrivateProfileInt("Other", "SetHeartTemp", 0, strFile);
	}
	
	if( pGREE_DLLWrCom( pDev->m_iPort, 
						pDev->m_iDevideaddr, 
						nWorkStatus,
						nWorkMode,
						nFanSpeed,
						nPutWind,
						nAirTrade,
						nSleep,
						nLight,
						nTempSetPoint) == 0 )
	{
		return 0;
	}
	else
	{
		return -1;
	}
}



void UnInitGreeDll()
{
	if (g_hGREELibModule != NULL && ( NULL != pGREE_DLLUnInit ))
	{
		pGREE_DLLUnInit();
	}

	DeleteCriticalSection( &g_csGreeReadOneData );
	if (g_hGREELibModule!= NULL)
	{
		AfxFreeLibrary(g_hGREELibModule);
		g_hGREELibModule = NULL;
	}
}