MiddleWare_SLWY/Middleware-S.../TFB/AgentBusines...

#include "StdAfx.h"
#include "AgentBusiness.h"
#include "AgentClient.h"
#include "AgentLog.h"
#include "AgentEventManager.h"
#include "PduEntity.h"
#include "NetCtrlInterface.h"


CAgentBusiness::CAgentBusiness(CAgentClient* pClient)
{
	m_pAgentClient = pClient;
}


CAgentBusiness::~CAgentBusiness(void)
{
}

/*****************************************************************
**【函数名称】	SubscribeData
**【函数功能】	订阅
**【参数】		订阅类型, 订阅参数
**【返回值】  	订阅Id
****************************************************************/
BOOL CAgentBusiness::SubscribeData(LONG nType, LONG nParam)
{
	CPduEntity PduEntity(PDU_CMD_AGENT_SUBSCRIBE);
	PduEntity.SetDataUInt(1, m_pAgentClient->m_nAgentExtension);
	PduEntity.SetDataUInt(2,m_pAgentClient->m_nAgentNumber);
	PduEntity.SetDataInt(3, nParam);
	PduEntity.SetDataUInt(4, nType);
	
	// 发送命令
	return CInterfaceWindow::getCommInstance()->Send(&PduEntity, PDU_DEV_TYPE_ACD, 0);
}

/*****************************************************************
**【函数名称】	CancelSubscribeData
**【函数功能】	取消订阅数据
**【参数】		订阅类型, 订阅参数
**【返回值】  	订阅Id
****************************************************************/
BOOL CAgentBusiness::CancelSubscribeData(LONG nType, LONG nParam)
{
	CPduEntity PduEntity(PDU_CMD_AGENT_CANCEL_SUBSCRIBE);
	PduEntity.SetDataUInt(1, m_pAgentClient->m_nAgentExtension);
	PduEntity.SetDataUInt(2,m_pAgentClient->m_nAgentNumber);
	PduEntity.SetDataInt(3, nParam);
	PduEntity.SetDataUInt(4, nType);
	
	// 发送取消订阅命令
	return CInterfaceWindow::getCommInstance()->Send(&PduEntity, PDU_DEV_TYPE_ACD, 0);
}