#pragma once
#include "Component.h"
#include <string>
#include <functional>
#include <vector>
#include "MMSystem.h"
#pragma comment(lib,"winmm")


typedef std::function<void(void* pFrom, int)> ONPLCSTATECHANGED;
typedef std::function<void(void* pFrom, int)> ONPLCMONITORDATA;
typedef struct _PLCListener
{
	ONPLCSTATECHANGED		onStateChanged;
	ONPLCMONITORDATA		onMonitorData;
} PLCListener;

typedef struct _MONITOR
{
	int id;
	int beginAddr;
	int readLen;
	MC::SOFT_COMPONENT softComponent;
	char* szRecvBuffer;
	HANDLE hEvent;
	ULONGLONG readCount;
} MONITOR;

enum class PLCSTATE
{
	READY = 0,
	CONNECTING,
	CONNECTED,
	DISCONNECTED
};

class CPLC :
	public CComponent
{
public:
	CPLC();
	CPLC(const char* pszName, const char* pszIP, unsigned int nPort);
	virtual ~CPLC();

public:
	virtual std::string& getClassName();
	void setListener(PLCListener& listener);
	static CString& dataToHexString(const char* pData, const int size, CString& strOut);
	void setActionInterval(unsigned int nInterval);
	void init();
	void term();
	bool isConnected();
	unsigned onMonitor();
	void OnTimer(UINT nTimerid);
	std::string& getIP();
	unsigned int getPort();
	int addMonitor(int id, int beginAddr, int endAddr, MC::SOFT_COMPONENT softComponent, char* pszRecvBuffer);
	int readWord(MC::SOFT_COMPONENT softComponent, unsigned int addr, ONREAD funOnRead);
	int readData(MC::SOFT_COMPONENT softComponent, unsigned int addr, unsigned int nReadLen, ONREADDATA funOnReadData);
	int writeWord(MC::SOFT_COMPONENT softComponent, unsigned int addr, int value, ONWRITE funOnWrite);
	int writeBit(MC::SOFT_COMPONENT softComponent, unsigned int addr, BOOL bValue, ONWRITE funOnWrite);
	int writeData(MC::SOFT_COMPONENT softComponent, unsigned int addr, const char* pszData, unsigned int length, ONWRITE funOnWrite);

private:
	void setState(PLCSTATE state);
	void monitorReadData(MONITOR& monitor);

private:
	std::string m_strName;
	std::string m_strIP;
	unsigned int m_nPort;
	IMcChannel* m_pChannel;
	PLCSTATE m_state;
	unsigned int m_nActionInterval;
	PLCListener m_listener;
	unsigned int m_nUnHeartBeat;

private:
	std::vector<MONITOR> m_monitors;
	HANDLE m_hMcMonitorStop;
	HANDLE m_hMcMonitorThreadHandle;
	unsigned m_mcMonitorThrdaddr;
	MMRESULT m_nTimerId;

public:
	HANDLE m_hTimeEvent;
};