Middlewares-Linux/CallOut/EslGateway.cpp

#include "EslGateway.h"
#include <thread>
#include <regex>
#include "pubdef.h"
#include "Config.h"
#include "Log.h"

#include "Util.h"

#define ESL_CMD_SCAN_CHANNELS				"api show channels\n\n"
#define ESL_CMD_SCAN_INTERNAL				"api sofia status profile internal reg\n\n"

#define ESL_HEADER_CALLID					"Channel-Call-UUID"
#define ESL_HEADER_CCID		                "variable_cc_member_session_uuid"    // freeswitchs自带的callcenter模块转接坐席后，callid产生变化，可通过该通道变量进行关联

#define ESL_HEADER_CHANID					"Unique-ID"
#define ESL_HEADER_CALLER					"Caller-Caller-ID-Number"
#define ESL_HEADER_CALLEE					"Caller-Callee-ID-Number"
#define ESL_HEADER_DEST_NUM					"Caller-Destination-Number"
#define ESL_HEADER_DIRECTION				"Call-Direction"
#define ESL_HEADER_SUBCLASS					"Event-Subclass"
#define ESL_HEADER_EXTEN_NO					"username"

// ESL事件头域常量值
#define ESL_HDR_DIRECTION_INBOUND			"inbound"
#define ESL_HDR_DIRECTION_OUTBOUND			"outbound"
#define ESL_HDR_SUBCLASS_SIP_REG			"sofia::register"
#define ESL_HDR_SUBCLASS_SIP_UNREG			"sofia::unregister"


EslGateway::EslGateway() :m_Stop(true), m_pEventThread(nullptr), m_trunkTotal(0), m_usedCount(0), m_bIsConn(false)
{
}

EslGateway::EslGateway(int nTrunkCount) : m_Stop(true), m_pEventThread(nullptr), m_trunkTotal(nTrunkCount), m_usedCount(0), m_bIsConn(false)
{
}

EslGateway::~EslGateway()
{
}


bool EslGateway::init(const std::string & strIP, const std::int16_t & nPort, const std::string & strPwd)
{
	this->m_strIP = strIP;
	this->m_nPort = nPort;
	this->m_strPwd = strPwd;
	return start();
}

bool EslGateway::start()
{
	memset(&m_EslHdl4Listen, '\0', sizeof(esl_handle_t));
	memset(&m_EslHdl4Send, '\0', sizeof(esl_handle_t));

	LOG_INFO("{EslGateway}: 处理客户端连接, ip = %s,port=%d,pwd=%s", this->m_strIP.c_str(), this->m_nPort, this->m_strPwd.c_str());

	esl_connect(&m_EslHdl4Listen, this->m_strIP.c_str(), this->m_nPort, NULL, this->m_strPwd.c_str());
	if (!m_EslHdl4Listen.connected)
		return false;
	LOG_INFO("{EslGateway}: 处理客户端连接m_EslHdl4Listen OK");

	esl_events(&m_EslHdl4Listen, ESL_EVENT_TYPE_PLAIN,
		("CHANNEL_CREATE CHANNEL_ANSWER CHANNEL_HANGUP_COMPLETE"));

	esl_connect(&m_EslHdl4Send, this->m_strIP.c_str(), this->m_nPort, NULL, this->m_strPwd.c_str());
	if (!m_EslHdl4Send.connected) {
		esl_disconnect(&m_EslHdl4Listen);
		return false;
	}
	scanUsedCount();
	scanExten();
	m_Stop = false;
	if (m_pEventThread == nullptr) {
		m_pEventThread = std::make_unique<boost::thread>(std::bind(&this_type::__eventThread, this));
	}
	m_bIsConn.store(true);
	return true;
}

void EslGateway::stop()
{
	m_Stop.store(true);
	if (m_pEventThread) {
		m_pEventThread->interrupt();
		m_pEventThread->join();
		m_pEventThread.reset();
	}
	memset(&m_EslHdl4Listen, '\0', sizeof(esl_handle_t));
	memset(&m_EslHdl4Send, '\0', sizeof(esl_handle_t));
}

void EslGateway::scanUsedCount()
{
	if (esl_send_recv(&m_EslHdl4Send, ESL_CMD_SCAN_CHANNELS) != ESL_SUCCESS)
		return;

	if (m_EslHdl4Send.last_sr_event == nullptr || m_EslHdl4Send.last_sr_event->body == nullptr)
		return;
	std::string body = m_EslHdl4Send.last_sr_event->body;
	body = std::regex_replace(body, std::regex(R"(\D)"), "$1");
	int n = atoi(body.c_str());
	m_usedCount = n;
	LOG_INFO("当前线路总数量:%d", m_trunkTotal.load());
	LOG_INFO("当前已用数量:%d", m_usedCount.load());
	LOG_INFO("当前可用数量:%d",m_trunkTotal.load()-m_usedCount.load());
	
}

void EslGateway::scanExten()
{
	if (esl_send_recv(&m_EslHdl4Send, ESL_CMD_SCAN_INTERNAL) != ESL_SUCCESS)
		return;

	if (m_EslHdl4Send.last_sr_event == nullptr || m_EslHdl4Send.last_sr_event->body == nullptr)
		return;
	std::string body = m_EslHdl4Send.last_sr_event->body;

	std::list<std::string> rows;
	boost::split(rows, body, boost::is_any_of("\n"));

	while (!rows.empty()) {
		std::string var = rows.front();
		rows.pop_front();
		std::regex space("\t| ");
		var = std::regex_replace(var, space, "");
		std::regex reg("IP:(.*)");
		if (std::regex_match(var, reg)) {
			std::string extenNo, extenIP;
			extenIP = std::regex_replace(var, reg, "$1");
			while (!rows.empty()) {
				var = rows.front();
				rows.pop_front();
				std::regex space("\t| ");
				var = std::regex_replace(var, space, "");
				reg = std::regex("Auth-User:(.*)");
				if (std::regex_match(var, reg)) {
					extenNo = std::regex_replace(var, reg, "$1");
					if (!extenNo.empty() && !extenIP.empty()) {
						LOG_DEBUG("分机注册：%s  %s", extenNo.c_str(), extenIP.c_str());
						__addExtenChan(extenNo);
					}
					break;
				}
			}
		}
	}
}

bool EslGateway::execPlay(const std::string & strChanId, const std::string & strFilePath)
{
	execte("set", "playback_terminators=none", strChanId);
	return execte("playback", strFilePath.c_str(), strChanId);
}

bool EslGateway::excDetectSpeech(const std::string & strChanId)
{
	return execte("detect_speech", "unimrcp:mrcpv2 hello hello", strChanId);
}

bool EslGateway::excDetectSpeechPause(const std::string & strChanId)
{
	return execte("detect_speech", "pause", strChanId);
}

bool EslGateway::excDetectSpeechResume(const std::string & strChanId)
{
	return execte("detect_speech", "resume", strChanId);
}

bool EslGateway::excPlayAndDetectSpeech(const std::string & strChanId, const std::string & strFilePath)
{
	return execte("play_and_detect_speech", "ivr/say_yes_or_no.wavdetect:unimrcp {start-input-timers=false,no-input-timeout=5000,recognition-timeout=5000}builtin:grammar/boolean?language=en-US;y=1;n=2", strChanId);
}

bool EslGateway::execte(const std::string & strApp, const std::string & strParam, const std::string & strChanId)
{
	esl_status_t Status = esl_execute(&m_EslHdl4Send, strApp.c_str(), strParam.c_str(), strChanId.c_str());
	return Status == ESL_SUCCESS;
}

bool EslGateway::sendCmd(const std::string & pCmd)
{
	esl_status_t Status = esl_send_recv(&m_EslHdl4Send, pCmd.c_str());
	return Status == ESL_SUCCESS;
}

void EslGateway::__eventThread(void)
{
	esl_event_t* pEvent = nullptr;
	esl_handle_t* pListenHandle = &m_EslHdl4Listen;
	// 下面的设置保证执行同时多个APP时，后面的不会抢占前面的
	pListenHandle->event_lock = 1;
	while (!m_Stop)
	{
		// esl_recv_event会阻塞线程，其第二个参数为1，表示优先检查内部缓存列表，防止遗漏事件。
		auto status = esl_recv_event(pListenHandle, 1, nullptr);
		if ((status == ESL_SUCCESS || status == ESL_BREAK) && !m_Stop)
		{
			pEvent = pListenHandle->last_ievent;
			if (pEvent != nullptr)
			{
				__onEslEvent(pEvent);
			}
		}
		else  // 连接中断
		{
			m_bIsConn.store(false);
			// 连接中断
			LOG_WARN_S("FS链接断开...");
			do
			{
				LOG_WARN_S("FS 3秒后自动重连...");
				std::this_thread::sleep_for(std::chrono::seconds(3));
				LOG_WARN_S("FS开始重连...");
			} while (!start() && !m_Stop);
		}
	}

}

void EslGateway::__onEslEvent(esl_event_t * pEvent)
{
	switch (pEvent->event_id) {
	case ESL_EVENT_CHANNEL_CREATE:
	{
		m_usedCount++;
	}
		break;
	case ESL_EVENT_CHANNEL_HANGUP_COMPLETE:
	{
		m_usedCount--; 
	}
		break;
	default:
		break;
	}
}

void EslGateway::__onEslEvtChanEvent(esl_event_t * pEvent)
{
	// 获取会话ID
	std::string strCallID = "";
	if ((strCallID = std::to_string(esl_event_get_header(pEvent, ESL_HEADER_CCID))) == "") {
		strCallID = std::to_string(esl_event_get_header(pEvent, ESL_HEADER_CALLID));
	}
	// 获取通道ID
	const auto pChanID = esl_event_get_header(pEvent, ESL_HEADER_CHANID);
	const std::string strChanID = std::to_string(pChanID);
	// 获取主被叫
	std::string strCaller = std::to_string(esl_event_get_header(pEvent, ESL_HEADER_CALLER));
	std::string strCallee = std::to_string(esl_event_get_header(pEvent, ESL_HEADER_CALLEE));
	if (strCallee == "") {
		strCallee = std::to_string(esl_event_get_header(pEvent, ESL_HEADER_DEST_NUM));
	}

	// 获取通道方向
	/*CALL_DIRECTION emDirection;
	if (strcmp(esl_event_get_header(pEvent, ESL_HEADER_DIRECTION), ESL_HDR_DIRECTION_INBOUND) == 0)
		emDirection = CALL_DIRECTION_INBOUND;
	else
		emDirection = CALL_DIRECTION_OUTBOUND;*/

	switch (pEvent->event_id)
	{
	case ESL_EVENT_CHANNEL_CREATE:
	{
		LOG_INFO_S(boost::str(Format("ESL通道创建事件[%s][%s]") % strCallID %strChanID));

	}
	break;
	case ESL_EVENT_CHANNEL_ANSWER:
	{
		LOG_INFO_S(boost::str(Format("ESL通道接听事件[%s][%s]") % strCallID %strChanID));

	}
	break;
	case ESL_EVENT_CHANNEL_HANGUP_COMPLETE:
	{
		LOG_INFO_S(boost::str(Format("ESL通道挂机事件[%s][%s]") % strCallID %strChanID));

	}
	break;
	default:
		break;
	}
}

void EslGateway::__hangupEvent(esl_event_t * pEvent)
{
}

void EslGateway::__detectSpeech(esl_event_t * pEvent)
{
	std::string strCallID = "";
	auto pCallID = esl_event_get_header(pEvent, ESL_HEADER_CALLID);
	strCallID = pCallID == nullptr ? "" : pCallID;
	auto pCallCCID = esl_event_get_header(pEvent, ESL_HEADER_CCID);
	if (pCallCCID != nullptr) {
		strCallID = pCallCCID;
	}
	// 获取通道ID
	std::string strChanID = "";
	auto pChanID = esl_event_get_header(pEvent, ESL_HEADER_CHANID);
	strChanID = pChanID == nullptr ? "" : pChanID;

	char* speechType = nullptr;
	speechType = esl_event_get_header(pEvent, "Speech-Type");
	if (speechType == nullptr) {
		LOG_WARN_S(boost::str(Format("ESL语音识别事件[%s][%s],Speech-Type 空") % strCallID %strChanID));
		return;
	}
	LOG_INFO_S(boost::str(Format("ESL语音识别事件[%s][%s][%s]") % speechType % strCallID %strChanID));

	if (strcmp(speechType, "begin-speaking") == 0) {

	}
	else if (strcmp(speechType, "detected-speech") == 0)
	{
		excDetectSpeechPause(strChanID);      // 暂停识别 

		char* result = esl_event_get_body(pEvent);
		if (result) {
			LOG_DEBUG("%s", result);
			std::string  strRes, err;
			parseASRXml(result, strRes, err);

			LOG_INFO_S(boost::str(Format("识别结果:\n[%s]") % strRes));
			std::wstring wsRes = string2wstring(strRes);
			if (strRes == "") { // 没有识别到说的内容
				execPlay(pChanID, "E:\\zhinengwav\\empty.wav");
			}
			/*else if (wsRes.compare(L"人工") == 0) {*/
			else if (strRes.find("人工") != std::string::npos) {
				execte("set", "trunkCallIn=2", strChanID);
				execPlay(pChanID, "E:\\zhinengwav\\turnagent.wav");
			}
			else {
				
			}

		}
	}
}

void EslGateway::__onEslEvtChanExecComplete(esl_event_t * pEvent)
{
	auto isTrunkCallIn = esl_event_get_header(pEvent, "variable_trunkCallIn");
	if (isTrunkCallIn == NULL || strcmp(isTrunkCallIn, "1") == 0 || strcmp(isTrunkCallIn, "2") == 0) return;

	auto ChanId = esl_event_get_header(pEvent, ESL_HEADER_CHANID);
	const char* pApp = esl_event_get_header(pEvent, "Application");
	LOG_INFO("通道[%s]执行APP[%s]完成", ChanId, pApp);
	if (strcmp(pApp, "playback") == 0) {
		LOG_INFO("通道[%s]放音完成,继续识别", ChanId);
		excDetectSpeechResume(ChanId);      // 放音完成，继续识别
	}

}

void EslGateway::__onEslEvtCustom(esl_event_t * pEvent)
{
	const char* pSubClass = esl_event_get_header(pEvent, ESL_HEADER_SUBCLASS);
	if (pSubClass == nullptr)return;
	auto HeaderValue = esl_event_get_header(pEvent, ESL_HEADER_EXTEN_NO);
	if (strcmp(pSubClass, ESL_HDR_SUBCLASS_SIP_REG) == 0) { // 分机注册
		if (HeaderValue == nullptr) return;
		__addExtenChan(std::to_string(HeaderValue));
	}
	else if (strcmp(pSubClass, ESL_HDR_SUBCLASS_SIP_UNREG) == 0) { // 分机取消注册
		if (HeaderValue == nullptr) return;
		__delExtenChan(std::to_string(HeaderValue));
	}
}

void EslGateway::__onEslEvtPark(esl_event_t * pEvent)
{
	// 获取通道ID
	auto ChanId = esl_event_get_header(pEvent, ESL_HEADER_CHANID);
	if (ChanId == NULL)return;
	// 获取通道方向
	auto Direct = esl_event_get_header(pEvent, ESL_HEADER_DIRECTION);
	if (!Direct || strcmp(Direct, ESL_HDR_DIRECTION_INBOUND) != 0) return;
	auto isTrunkCallIn = esl_event_get_header(pEvent, "variable_trunkCallIn");
	if (isTrunkCallIn == NULL || strcmp(isTrunkCallIn, "1") != 0) return;
	auto strCaller = esl_event_get_header(pEvent, ESL_HEADER_CALLER);
	execte("set", "trunkCallIn=0", ChanId);
	excDetectSpeech(ChanId);
	//excPlayAndDetectSpeech("E:\\zhinengwav\\welcome.wav",ChanId);
	LOG_INFO("来电[%s]进入智能语音系统", strCaller);
}

void EslGateway::__addExtenChan(const std::string & strNo)
{
	LOG_INFO_S(boost::str(Format("分机[%s]注册") % strNo));
}

void EslGateway::__delExtenChan(const std::string & strNo)
{
	LOG_INFO_S(boost::str(Format("分机[%s]注册取消成功") % strNo));
}

std::string EslGateway::__createJson(const std::string & strType, const bool & bOk, const std::string&strDesc)
{
	Json::Value root;
	root["Type"] = strType;
	root["Result"] = bOk;
	root["Desc"] = strDesc;
	Json::StreamWriterBuilder builder;
	return Json::writeString(builder, root);
}