midware_ws/NetLib/RcfClient/RcfClient.cpp

// RcfClient.cpp : 定义静态库的函数。
//
#include <iostream>
#include "RcfClient.h"
#include "RCF\RcfInterface.h"
#include "RCF\RcfConfig.h"

bool pushAgentList(int agentId, std::string agentList)
{
	try
	{
		RCF::RcfInit rcfInit;
		auto pCfg = RcfConfig::GetInstance();
		RcfClient<I_RcfEcho> client(RCF::TcpEndpoint(pCfg->RcfIP(), pCfg->RcfPort()));
		client.getClientStub().setServerBindingName("agent");
		bool ret = client.pushAgentList(agentId, agentList);
		return ret;
	}
	catch (const RCF::Exception & e)
	{
		std::cout << e.getErrorMessage() << std::endl;
		return false;
	}
	return true;
}

bool getAgentList(int agentId, std::string & agentList)
{
	try
	{
		RCF::RcfInit rcfInit;
		auto pCfg = RcfConfig::GetInstance();
		RcfClient<I_RcfEcho> client(RCF::TcpEndpoint(pCfg->RcfIP(), pCfg->RcfPort()));
		client.getClientStub().setServerBindingName("agent");
		bool ret = client.getAgentList(agentId, agentList);
		return ret;
	}
	catch (const RCF::Exception & e)
	{
		std::cout << e.getErrorMessage() << std::endl;
		return false;
	}
	return true;
}

bool pushRedis(std::vector<std::string>& val)
{
	try
	{
		RCF::RcfInit rcfInit;
		auto pCfg = RcfConfig::GetInstance();
		RcfClient<I_RcfEcho> client(RCF::TcpEndpoint(pCfg->RcfIP(), pCfg->RcfPort()));
		client.getClientStub().setServerBindingName("agent");
		bool ret = client.pushRedis(val);
		return ret;
	}
	catch (const RCF::Exception & e)
	{
		std::cout << e.getErrorMessage() << std::endl;
		return false;
	}
	return true;
}

bool pushRedis(std::string & val)
{
	try
	{
		RCF::RcfInit rcfInit;
		auto pCfg = RcfConfig::GetInstance();
		RcfClient<I_RcfEcho> client(RCF::TcpEndpoint(pCfg->RcfIP(), pCfg->RcfPort()));
		client.getClientStub().setServerBindingName("agent");
		std::vector<std::string> vec;
		vec.emplace_back(val);
		bool ret = client.pushRedis(vec);
		return ret;
	}
	catch (const RCF::Exception & e)
	{
		std::cout << e.getErrorMessage() << std::endl;
		return false;
	}
	return true;
}

bool pushCallIndex(std::string callIndex)
{
	try
	{
		RCF::RcfInit rcfInit;
		auto pCfg = RcfConfig::GetInstance();
		RcfClient<I_RcfEcho> client(RCF::TcpEndpoint(pCfg->RcfIP(), pCfg->RcfPort()));
		client.getClientStub().setServerBindingName("agent");
		bool ret = client.pushCallIndex(callIndex);
		return ret;
	}
	catch (const RCF::Exception & e)
	{
		std::cout << e.getErrorMessage() << std::endl;
		return false;
	}
	return true;
}

bool getCallIndex(int index, std::string & callIndex)
{
	try
	{
		RCF::RcfInit rcfInit;
		auto pCfg = RcfConfig::GetInstance();
		RcfClient<I_RcfEcho> client(RCF::TcpEndpoint(pCfg->RcfIP(), pCfg->RcfPort()));
		client.getClientStub().setServerBindingName("agent");
		//client.getClientStub().setConnectTimeoutMs(1 * 1000);
		//client.getClientStub().setRemoteCallTimeoutMs(1 * 1000);
		bool ret = client.getCallIndex(index,callIndex);
		return ret;
	}
	catch (const RCF::Exception & e)
	{
		std::cout << e.getErrorMessage() << std::endl;
		return false;
	}
	return true;
}

bool pushSubmitData(int nAgentID, int nEventType, std::string state)
{
	try
	{
		RCF::RcfInit rcfInit;
		auto pCfg = RcfConfig::GetInstance();
		RcfClient<I_RcfEcho> client(RCF::TcpEndpoint(pCfg->RcfIP(), pCfg->RcfPort()));
		client.getClientStub().setServerBindingName("agent");
		bool ret = client.pushSubmitData(nAgentID, nEventType, state);
		return ret;
	}
	catch (const RCF::Exception & e)
	{
		std::cout << e.getErrorMessage() << std::endl;
		return false;
	}
	return true;
}

bool getSubmitData(int nAgentID, int nEventType, std::string & state)
{
	try
	{
		RCF::RcfInit rcfInit;
		auto pCfg = RcfConfig::GetInstance();
		RcfClient<I_RcfEcho> client(RCF::TcpEndpoint(pCfg->RcfIP(), pCfg->RcfPort()));
		client.getClientStub().setServerBindingName("agent");
		bool ret = client.getSubmitData(nAgentID, nEventType, state);
		return ret;
	}
	catch (const RCF::Exception & e)
	{
		std::cout << e.getErrorMessage() << std::endl;
		return false;
	}
	return true;
}

bool pushZmdExtenStateList(std::string & extList)
{
	try
	{
		RCF::RcfInit rcfInit;
		auto pCfg = RcfConfig::GetInstance();
		RcfClient<I_RcfEcho> client(RCF::TcpEndpoint(pCfg->RcfIP(), pCfg->RcfPort()));
		client.getClientStub().setServerBindingName("agent");
		bool ret = client.pushZmdExtenStateList(extList);
		return ret;
	}
	catch (const RCF::Exception & e)
	{
		std::cout << e.getErrorMessage() << std::endl;
		return false;
	}
	return true;
}

bool getZmdExtenStateList(std::string & extList)
{
	try
	{
		RCF::RcfInit rcfInit;
		auto pCfg = RcfConfig::GetInstance();
		RcfClient<I_RcfEcho> client(RCF::TcpEndpoint(pCfg->RcfIP(), pCfg->RcfPort()));
		client.getClientStub().setServerBindingName("agent");
		bool ret = client.getZmdExtenStateList(extList);
		return ret;
	}
	catch (const RCF::Exception & e)
	{
		std::cout << e.getErrorMessage() << std::endl;
		return false;
	}
	return true;
}

bool pushOnlineAgentGroupDetail(std::string & groupNo, std::string & agentList)
{
	try
	{
		RCF::RcfInit rcfInit;
		auto pCfg = RcfConfig::GetInstance();
		RcfClient<I_RcfEcho> client(RCF::TcpEndpoint(pCfg->RcfIP(), pCfg->RcfPort()));
		client.getClientStub().setServerBindingName("agent");
		client.getClientStub().setConnectTimeoutMs(1 * 1000);
		bool ret = client.pushOnlineAgentGroupDetail(groupNo,agentList);
		return ret;
	}
	catch (const RCF::Exception & e)
	{
		std::cout << e.getErrorMessage() << std::endl;
		return false;
	}
	return true;
}

bool getOnlineAgentGroupDetail(std::vector<std::string>& agentList)
{
	try
	{
		RCF::RcfInit rcfInit;
		auto pCfg = RcfConfig::GetInstance();
		RcfClient<I_RcfEcho> client(RCF::TcpEndpoint(pCfg->RcfIP(), pCfg->RcfPort()));
		client.getClientStub().setServerBindingName("agent");
		bool ret = client.getOnlineAgentGroupDetail(agentList);
		return ret;
	}
	catch (const RCF::Exception & e)
	{
		std::cout << e.getErrorMessage() << std::endl;
		return false;
	}
	return true;
}

bool delOnlineAgentGroupDetail(int agentID, int extenNo)
{
	try
	{
		RCF::RcfInit rcfInit;
		auto pCfg = RcfConfig::GetInstance();
		RcfClient<I_RcfEcho> client(RCF::TcpEndpoint(pCfg->RcfIP(), pCfg->RcfPort()));
		client.getClientStub().setServerBindingName("agent");
		bool ret = client.delOnlineAgentGroupDetail(agentID, extenNo);
		return ret;
	}
	catch (const RCF::Exception & e)
	{
		std::cout << e.getErrorMessage() << std::endl;
		return false;
	}
	return true;
}

bool clearOnlineAgentGroupDetail()
{
	try
	{
		RCF::RcfInit rcfInit;
		auto pCfg = RcfConfig::GetInstance();
		RcfClient<I_RcfEcho> client(RCF::TcpEndpoint(pCfg->RcfIP(), pCfg->RcfPort()));
		client.getClientStub().setServerBindingName("agent");
		bool ret = client.clearOnlineAgentGroupDetail( );
		return ret;
	}
	catch (const RCF::Exception & e)
	{
		std::cout << e.getErrorMessage() << std::endl;
		return false;
	}
	return true;
}

bool pushCtiState(bool isRun)
{
	try
	{
		RCF::RcfInit rcfInit;
		auto pCfg = RcfConfig::GetInstance();
		RcfClient<I_RcfEcho> client(RCF::TcpEndpoint(pCfg->RcfIP(), pCfg->RcfPort()));
		client.getClientStub().setServerBindingName("agent");
		bool ret = client.pushCtiState(isRun);
		return ret;
	}
	catch (const RCF::Exception & e)
	{
		std::cout << e.getErrorMessage() << std::endl;
		return false;
	}
	return true;
}

bool getCtiState()
{
	try
	{
		RCF::RcfInit rcfInit;
		auto pCfg = RcfConfig::GetInstance();
		RcfClient<I_RcfEcho> client(RCF::TcpEndpoint(pCfg->RcfIP(), pCfg->RcfPort()));
		client.getClientStub().setServerBindingName("agent");
		bool ret = client.getCtiState();
		return ret;
	}
	catch (const RCF::Exception & e)
	{
		std::cout << e.getErrorMessage() << std::endl;
		return false;
	}
	return true;
}