// DispatchTaskManger.h : DispatchTaskManger DLL 的主头文件
#pragma once

#include "CBaseDispatchTaskMg.h"

class CDispatchTaskMG : public CBaseDispatchTaskMg,public CDispatchMng_I
{
public:
	 CDispatchTaskMG();
	~CDispatchTaskMG(void);
private:
	NETDATA_CALLBACK	m_pTCPSend_CallBack;
	NETDATA_CALLBACK	m_pUDPSend_CallBack;

public:
	virtual bool StartWork( CFrameTool_I* pFrmTool );

public:
	virtual CBaseDispatch* CreateNewTaskType( int nSysType );
	virtual void Deal_NetComand( OCCCOMMAND& NetCmd );
	virtual bool InitConfigParam();
	virtual bool InitNetConnectStatus ( int nTrainID,int nSysType );
	virtual void AddReceiveGroupMsg   ( int nTrainID,int nSysType,CBaseDispatch* pDispatchSys );
	virtual void DeleteReceiveGroupMsg( int nTrainID,int nSysType );

	//接口实现类
	virtual LPVOID _IGetPtr_DebugModule()		{ return m_pDebugModule; }
	virtual LPVOID _IGetPtr_NetWorkModule()		{ return m_pNetWork;	 }
	virtual LPVOID _IGetPtr_RedisModule()		{ return &m_RedisClient; }
	virtual LPVOID _IGetPtr_FrameTool()			{ return m_pFrmTool;	 }
	virtual LPVOID _IGetPtr_CmdQueue(int nType);
	virtual LPVOID _IGetPtr_TrainingCS()		{ return &m_MutexTrainConect;}
	virtual LPVOID _IGetPtr_SysListMap()		{ return &m_NetTrainNectMap; }
	virtual LPVOID _IGetPtr_TCPSend_CallBack()	{ return (LPVOID)m_pTCPSend_CallBack;}
	virtual LPVOID _IGetPtr_UDPSend_CallBack()  { return (LPVOID)m_pUDPSend_CallBack;}
	virtual BOOL   _ITCPData_2Server(char* pData, int nDateLen);
	virtual BOOL   _IUDPData_2Server(char* pData, int nDateLen);

public:
	virtual int  _IGetCnt_RecvQue_TCP()				{ return m_QI_GetList_TCP.GetCur_Count(); }
	virtual int  _IGetCnt_RecvQue_UDP()				{ return m_QI_GetList_UDP.GetCur_Count(); }

public:
	virtual int  _IGetTime_Simulate()				{ return m_nSysSimulateTime;	 }
	virtual void _ISetTime_Simulate(int nSimTime)	{ m_nSysSimulateTime = nSimTime; }

public:
	virtual void  _IAdd_Sub_Sys(int nTrainingID, int nSysType, int nSysID);

	virtual BOOL  _ISend_UDPData_ToModule(int nModuleID, long lSysID, 
									      char* pDataBuf,int nLength);

	BOOL LoadSubSys_DBConfig(int nSubSysType);
};