#include "StdAfx.h"
#include "CHSignalControls/SignalControl_MxComponent.h"
#include "SharedMemoryDefine.h"

CSignalControl_MxComponent::CSignalControl_MxComponent(int nIndex, DWORD dwPeriod) : CSignalControl(nIndex, dwPeriod)
	, m_ReadEvent(FALSE, FALSE, _T("DIT_PLCConnector_Event_1"))
	, m_WriteEvent(FALSE, FALSE, _T("DIT_PLCConnector_Write_Complete_Event_1"))
{
	m_hMemMap		= NULL;
	m_pMemStartAddr	= NULL;

}

CSignalControl_MxComponent::~CSignalControl_MxComponent(void)
{
	//AfxMessageBox(_T("CSignalControl_MxComponent"));

	Disconnect();
}

int	CSignalControl_MxComponent::Connect(const CSignalControlInfo* pControlInfo)
{
	if (pControlInfo==NULL) return 0;
	m_ControlInfo = *pControlInfo;

	// set signal info
	if (m_ControlInfo.GetIndex() < 0) return -1;

	m_nIndex = m_ControlInfo.GetIndex();

	m_nReceiveSignalCount = m_ControlInfo.GetReceiveSignalCount();
	m_nSendSignalCount = m_ControlInfo.GetSendSignalCount();

	// new signal pointer
	m_pReceiveSignalValue = new WORD[m_nReceiveSignalCount];   
	m_pReceiveSignalValuePrev = new WORD[m_nReceiveSignalCount];
	memset(m_pReceiveSignalValue, 0, sizeof(WORD)*m_nReceiveSignalCount);
	memset(m_pReceiveSignalValuePrev, 0, sizeof(WORD)*m_nReceiveSignalCount);

	m_pSendSignalValue = new WORD[m_nSendSignalCount];   
	m_pSendSignalValuePrev = new WORD[m_nSendSignalCount];
	memset(m_pSendSignalValue, 0, sizeof(WORD)*m_nSendSignalCount);
	memset(m_pSendSignalValuePrev, 0, sizeof(WORD)*m_nSendSignalCount);


	// 4k Å©±âÀÇ °øÀ¯ ¸Þ¸ð¸® ÆÄÀÏ »ý¼º
	m_hMemMap = ::CreateFileMapping(INVALID_HANDLE_VALUE, NULL, PAGE_READWRITE, 0, SHARED_MEMORY_SIZE, PC_SHARED_MEMORY_NAME);

	// ¸¸ÀÏ ÀÌ¹Ì »ý¼ºµÈ °´Ã¼°¡ ÀÖ´Ù¸é ÀÌ¹Ì Connector°¡ ÀÛµ¿ Áß..
	if (::GetLastError() == ERROR_ALREADY_EXISTS)
	{
		// ÀÌ¹Ì »ý¼ºµÈ °´Ã¼°¡ ÀÖ´Ù¸é »ý¼ºÀÌ ¾Æ´Ï¶ó ¿ÀÇÂÀ¸·Î ½ÇÇà
		m_hMemMap = ::OpenFileMapping(FILE_MAP_ALL_ACCESS, FALSE, PC_SHARED_MEMORY_NAME);
	}
	else // ¸¸ÀÏ »ý¼ºµÈ °´Ã¼°¡ ¾ø´Ù¸é Á¤»ó µ¿ÀÛÇÏÁö ¾Ê´Â´Ù.
	{
		if (m_hMemMap == NULL) return -2;
	}

	//°øÀ¯¸Þ¸ð¸® ¸ÊÇÎ
	m_pMemStartAddr = (char*)::MapViewOfFile(m_hMemMap, FILE_MAP_ALL_ACCESS, 0, 0, SHARED_MEMORY_SIZE);

	if (m_pMemStartAddr == NULL) return -3;

	//0À¸·Î ÃʱâÈ­
	ZeroMemory(m_pMemStartAddr, SHARED_MEMORY_SIZE);       

	m_bConnected = TRUE;

	return 1;

}

void CSignalControl_MxComponent::Disconnect()
{
	if (m_pMemStartAddr!=NULL)
	{
		::UnmapViewOfFile(m_pMemStartAddr);
		m_pMemStartAddr = NULL;
	}

	if (m_hMemMap != NULL)
	{
		::CloseHandle(m_hMemMap);
		m_hMemMap = NULL;
	}
}

int CSignalControl_MxComponent::Hex2Dec(const CString& hex_str)
{
	CString hex("0123456789ABCDEF");

	int		cnv = 1;
	int     dec = 0;
	for(int i=0 ; i<hex_str.GetLength() ; i++)
	{
		dec += hex.Find(hex_str.GetAt(hex_str.GetLength()-1-i))*cnv;
		cnv *= 16;
	}
	return dec;
}

BOOL CSignalControl_MxComponent::Read_ReceiveSignal(int nAddrIndex, WORD& wValue)
{
	if(m_pMemStartAddr == NULL) return FALSE;
		
	int nAddress = PLC_READ_SIGNAL0 + (sizeof(WORD)*nAddrIndex);

	// copy signal
	memcpy(&wValue, m_pMemStartAddr+nAddress, sizeof(WORD));

	// make string
	CString strValue = _T("");
	strValue.Format(_T("%x"), wValue);		
	strValue.MakeUpper();

	// hex 2 dec
	wValue = Hex2Dec(strValue);

	return TRUE;
}

BOOL CSignalControl_MxComponent::Read_SendSignal(int nAddrIndex, WORD& wValue)
{
	if(m_pMemStartAddr == NULL) return FALSE;

	if (m_ControlInfo.GetIndex() < 0) return FALSE;

	int nAddress = PLC_WRITEWORD_VALUE + (sizeof(WORD)*nAddrIndex);

	memcpy(&wValue, m_pMemStartAddr+nAddress, sizeof(WORD));
	
	CString strValue = _T("");
	strValue.Format(_T("%x"), wValue);		
	strValue.MakeUpper();

	wValue = Hex2Dec(strValue);

	return TRUE;
}


BOOL CSignalControl_MxComponent::Write_SendSignal(int nAddrIndex, int nSignalIndex, WORD nSignalValue, int nOnTime)
{
	if(m_pMemStartAddr == NULL) return FALSE;

	if (m_ControlInfo.GetIndex() < 0) return FALSE;

	CString strAddr = m_ControlInfo.GetSendSignalAddress(nAddrIndex);
	int strlength =  lstrlen(strAddr);
	if ( strlength > 6) strlength = 6;

	short WriteData = (nSignalValue << nSignalIndex);

	memset(m_pMemStartAddr+PLC_WRITEWORD_ADDRESS,	0x00,		7*sizeof(TCHAR));
	memcpy(m_pMemStartAddr+PLC_WRITEWORD_ADDRESS,	strAddr,	strlength*sizeof(TCHAR));
	memcpy(m_pMemStartAddr+PLC_WRITEWORD_VALUE,		&WriteData, 2);

	// typeÀÌ timerÀ̸é timer pram set
	if (nOnTime > 0)
	{
		memcpy(m_pMemStartAddr+PLC_WRITEWORD_TIMER,	&nOnTime, 2);
	}

	//¸ðµç °ªÀ» ä¿ö ³ÖÀº ÈÄ PLCConnector¿¡°Ô PLC ÁÖ¼Ò¿¡ °ªÀ» Àûµµ·Ï ½ÅÈ£¸¦ º¸³½´Ù.
	m_pMemStartAddr[PLC_WRITEWORD_SIGNAL] = 1;
	
	if (nAddrIndex == 1 )
	{
			m_bAlive = TRUE;
	}
	else 
	{
		m_bAlive = FALSE;
	}

	return TRUE;
}

BOOL CSignalControl_MxComponent::ReadData(const CString strAddr, int nSize, CString& strData)
{
	if(m_pMemStartAddr == NULL)	return FALSE;

	int strlength =  lstrlen(strAddr);
	if ( strlength > 6) strlength = 6;

	if( nSize > 1000) nSize = 1000;

	strData = _T("");

	//°øÀ¯ ¸Þ¸ð¸®¿¡ ¹°·ùµ¥ÀÌÅ͸¦ Àеµ·Ï ½ÅÈ£¸¦ º¸³½´Ù.
	memset(m_pMemStartAddr+PLC_READ_LONGDATA_SIGNAL_1, 0x01, 1);
	memcpy(m_pMemStartAddr+PLC_READ_LONGDATA_ADDRESS_1, strAddr, strlength*sizeof(TCHAR));
	memcpy(m_pMemStartAddr+PLC_READ_LONGDATA_LENGTH_1, &nSize, sizeof(unsigned short));

	//µ¥ÀÌÅ͸¦ ´Ù ÀÐ°í °øÀ¯¸Þ¸ð¸® ÀûÀ» ¶§±îÁö ±â´Ù¸°´Ù.
	m_ReadEvent.ResetEvent();
	::WaitForSingleObject(m_ReadEvent, 2000);

	//¿Ï·á°¡ µÇ¸é ÇØ´ç °ªÀ» Àоî¿Â´Ù.
	char pData[2048] = {0};
	memcpy(pData, m_pMemStartAddr+PLC_READ_LONGDATA_VALUE_1, nSize*sizeof(TCHAR));
	strData = pData;

	return TRUE;
}

BOOL CSignalControl_MxComponent::ReadData(const CString strAddr, int nSize, char* pData)
{
	if(m_pMemStartAddr == NULL)	return FALSE;

	int strlength =  lstrlen(strAddr);
	if ( strlength > 6) strlength = 6;

	if( nSize > 1000) nSize = 1000;

	//°øÀ¯ ¸Þ¸ð¸®¿¡ ¹°·ùµ¥ÀÌÅ͸¦ Àеµ·Ï ½ÅÈ£¸¦ º¸³½´Ù.
	memset(m_pMemStartAddr+PLC_READ_LONGDATA_SIGNAL_1, 0x01, 1);
	ZeroMemory(m_pMemStartAddr+PLC_READ_LONGDATA_ADDRESS_1, PLC_READ_ADDRESS_LENGTH);
	memcpy(m_pMemStartAddr+PLC_READ_LONGDATA_ADDRESS_1, strAddr, strlength*sizeof(TCHAR));
	memcpy(m_pMemStartAddr+PLC_READ_LONGDATA_LENGTH_1, &nSize, sizeof(unsigned short));

	//µ¥ÀÌÅ͸¦ ´Ù ÀÐ°í °øÀ¯¸Þ¸ð¸® ÀûÀ» ¶§±îÁö ±â´Ù¸°´Ù.
	m_ReadEvent.ResetEvent();
	::WaitForSingleObject(m_ReadEvent, 2000);

	//¿Ï·á°¡ µÇ¸é ÇØ´ç °ªÀ» Àоî¿Â´Ù.
	memcpy(pData, m_pMemStartAddr+PLC_READ_LONGDATA_VALUE_1, nSize*sizeof(TCHAR));

	return TRUE;
}

BOOL CSignalControl_MxComponent::WriteWordData(const CString strAddr, int nSize, int nData)
{
	if(m_pMemStartAddr == NULL)	return FALSE;

	if (m_ControlInfo.GetIndex() < 0) return FALSE;

	int strlength =  lstrlen(strAddr);
	if ( strlength > 6) strlength = 6;

	if( nSize > 1000) nSize = 1000;

	::WaitForSingleObject(m_WriteEvent, 1000);

	memset(m_pMemStartAddr+PLC_WRITELONG_ADDRESS, 0x00, 7*sizeof(TCHAR));
	memcpy(m_pMemStartAddr+PLC_WRITELONG_ADDRESS, strAddr, strlength*sizeof(TCHAR));
	memcpy(m_pMemStartAddr+PLC_WRITELONG_WORDLENGTH, &nSize, sizeof(unsigned short));
	memcpy(m_pMemStartAddr+PLC_WRITELONG_DATA, &nData, nSize);

	//¸ðµç °ªÀ» ä¿ö ³ÖÀº ÈÄ PLCConnector¿¡°Ô PLC ÁÖ¼Ò¿¡ °ªÀ» Àûµµ·Ï ½ÅÈ£¸¦ º¸³½´Ù.
	m_pMemStartAddr[PLC_WRITELONG_SIGNAL] = 1;

	return TRUE;
}

BOOL CSignalControl_MxComponent::WriteData(const CString strAddr, int nSize, CString strData)
{
	if(m_pMemStartAddr == NULL)	return FALSE;

	if (m_ControlInfo.GetIndex() < 0) return FALSE;

	int strlength =  lstrlen(strAddr);
	if ( strlength > 6) strlength = 6;

	if( nSize > 1000) nSize = 1000;

	//::WaitForSingleObject(m_WriteEvent, 1000);

	memset(m_pMemStartAddr+PLC_WRITELONG_ADDRESS, 0x00, 7*sizeof(TCHAR));
	memcpy(m_pMemStartAddr+PLC_WRITELONG_ADDRESS, strAddr, strlength*sizeof(TCHAR));
	memcpy(m_pMemStartAddr+PLC_WRITELONG_WORDLENGTH, &nSize, sizeof(unsigned short));
	memcpy(m_pMemStartAddr+PLC_WRITELONG_DATA, strData.GetBuffer(0), nSize*2);

	//¸ðµç °ªÀ» ä¿ö ³ÖÀº ÈÄ PLCConnector¿¡°Ô PLC ÁÖ¼Ò¿¡ °ªÀ» Àûµµ·Ï ½ÅÈ£¸¦ º¸³½´Ù.
	m_pMemStartAddr[PLC_WRITELONG_SIGNAL] = 1;

	return TRUE;
}


BOOL CSignalControl_MxComponent::WritePacketData(const CString strAddr, int nSize, short* pPacketData)
{
	if(m_pMemStartAddr == NULL)	return FALSE;
	if (m_ControlInfo.GetIndex() < 0) return FALSE;

	int strlength =  lstrlen(strAddr);
	if ( strlength > 6) strlength = 6;

	if( nSize > 1000) nSize = 1000;

	//::WaitForSingleObject(m_WriteEvent, 1000);

	memset(m_pMemStartAddr+PLC_WRITELONG_ADDRESS, 0x00, 14*sizeof(TCHAR));
	memcpy(m_pMemStartAddr+PLC_WRITELONG_ADDRESS, strAddr, strlength*sizeof(TCHAR));
	memcpy(m_pMemStartAddr+PLC_WRITELONG_WORDLENGTH, &nSize, sizeof(unsigned short));
	memcpy(m_pMemStartAddr+PLC_WRITELONG_DATA, pPacketData, nSize*2);

	//¸ðµç °ªÀ» ä¿ö ³ÖÀº ÈÄ PLCConnector¿¡°Ô PLC ÁÖ¼Ò¿¡ °ªÀ» Àûµµ·Ï ½ÅÈ£¸¦ º¸³½´Ù.
	m_pMemStartAddr[PLC_WRITELONG_SIGNAL] = 1;

	return TRUE;
}