Middlewares-Linux/FreeSWITCH-l.../OpMultiMeeti...

#include "OpMultiMeeting.h"
#include "VirtualChan.h"
#include "OperationReactor.h"
#include "FsProxy.h"
#include "Config.h"
#include "ChanExten.h"
#include "Session.h"

COpMultiMeeting::COpMultiMeeting(COperationReactor * pParent, long Instance) : COperation(pParent, Instance), m_Step(0), m_pAssoChan(nullptr),m_IsTakeBack(false)
{
}

COpMultiMeeting::~COpMultiMeeting(void)
{
}

bool COpMultiMeeting::start(LineOpParam * pParam)
{
	// 校验状态
	if (m_pHostChan->state() != CHAN_LOGIC_STATE_TALKING)
		return false;

	m_MeetingId = pParam->nParam1;  // callid
	m_CallerNum = pParam->szParam1;
	m_DestNumber = pParam->szParam2;

	// 判断被邀请会议的是否是内线分机
	uint32_t ExtenNo = 0;
	sscanf(pParam->szParam2.c_str(), "%lu", &ExtenNo);
	ChanExten* pExten = CFsProxy::GetInstance().getExten(ExtenNo);
	if (pExten != nullptr)
	{
		if (!pExten->isFree())
		{
			LOG_WARN(("{OpMeeting}: 分机[%lu]执行会议失败, 目标分机[%lu]非空闲"), m_pHostChan->no(), ExtenNo);
			return false;
		}

		// 若主叫为空，则置为发起会议的分机通道号
		if (m_CallerNum.empty())
			m_CallerNum = std::to_string(m_pHostChan->no());
	}

	// 通知启动日志
	LOG_INFO(("{OpMeeting}: 分机[%lu]执行会议, DestNum = %s"), m_pHostChan->no(), m_DestNumber.c_str());

	std::string caller_agent = CFsProxy::GetInstance().getAgentByExten(m_CallerNum);
	std::string callee_agent = CFsProxy::GetInstance().getAgentByExten(m_DestNumber);

	m_SessionId = m_MeetingId;
	m_Caller = m_CallerNum;
	m_CallerAgent = caller_agent;
	m_Callee = m_DestNumber;
	m_CalleeAgent = callee_agent;
	m_OpTime = Util::CurTime();

	{
		Format fmt("update rep_cdr set op_type = %d where uuid = '%s'");
		fmt % LINE_OP_CONFERENCE % m_MeetingId;
		SqlWrite::GetInstance()->addSql(fmt.str());
	}
	{

		Format fmt("insert into rep_conference(uuid,caller_agent,caller,callee_agent,callee,create_time) values('%s','%s','%s','%s','%s','%s')");
		fmt %m_MeetingId %caller_agent %m_CallerNum %callee_agent %m_DestNumber %m_OpTime;
		SqlWrite::GetInstance()->addSql(fmt.str());
	}

	if (m_pHostChan->isInMeeting())  // 如果已经在会议，则不需要转移到会议中，只需要把第三个人呼叫到会议，第一个人静音即可
	{
		m_Step = 6;
		return CFsProxy::GetInstance().meeting(uniqueId(), m_CallerNum, m_DestNumber, m_MeetingId);
	}
	else
	{
		m_Step = 1;
		m_pAssoChan = CFsProxy::GetInstance().getAssoChanInSession(m_pHostChan);
		if (m_pAssoChan == nullptr)return false;
		return CFsProxy::GetInstance().meeting(uniqueId(), m_CallerNum, m_DestNumber, m_MeetingId);
		//return CFsProxy::GetInstance().transfer2Context(uniqueId(), m_pHostChan->chanId(), m_MeetingId, CConfig::GetInstance()->meetingContext(), true);
	}
}

bool COpMultiMeeting::cancel(long InstanceCancel)
{
	LOG_INFO("{OpMeeting }: 分机[%lu]呼叫接回主叫", m_pHostChan->no());
	m_IsTakeBack = true;
	m_Instance = InstanceCancel;
	if (m_pAssoChan != NULL)
	{
		m_Step = 5;
		bool ret = CFsProxy::GetInstance().setConferenceIsMute(uniqueId(), m_MeetingId, m_memberId, false);
		return ret;
	}
	else
	{
		LOG_ERROR("{OpMeeting }: 分机[%lu]呼叫接回主叫失败，主叫已挂机", m_pHostChan->no());
	}
	return false;
}

void COpMultiMeeting::onBackgroudJobDone(PBG_JOB_NOTIFY pNotify)
{
	if (pNotify->JobBody.find(ESL_CMD_MAKE_CALL) == std::string::npos) { // 先呼叫
		_end(false);
	}
	else {
		if (pNotify->JobBody.find(ESL_JOB_DONE_RES_OK) == std::string::npos) {
			_end(false);
		}
		else {
			 
			if (m_Step == 2) { // 第三个人呼叫接通之后并将正在通话两人转入会议
				m_pHostChan->isInMeeting() = true;
				if (m_pAssoChan != nullptr)
					m_pAssoChan->isInMeeting() = true;
				std::this_thread::sleep_for(std::chrono::milliseconds(1000));
				if (!CFsProxy::GetInstance().getConferenceMemberId(m_MeetingId, m_pAssoChan->chanId(), m_memberId)){
					LOG_ERROR("{OpMultiMeeting}: 分机[%lu]执行会议失败, 会议成员id获取失败", m_pHostChan->no());
					_end(false);
				}
				else{
					CFsProxy::GetInstance().setConferenceExitSound(m_MeetingId, true);
					CFsProxy::GetInstance().setConferenceIsMute(-1, m_MeetingId, m_memberId, true);
					_end(true);
				}
			}
			else if (m_Step == 5) { // 接回主叫
				_end(true);
			}
		}
	}

}

void COpMultiMeeting::onAssoChanStateUpdated(VirtualChan * pAssoChan)
{
	if (pAssoChan == nullptr) return;
	switch ((int)pAssoChan->state())
	{
	case CHAN_LOGIC_STATE_ALERTING:
	case CHAN_LOGIC_STATE_RING_BACK:
	{
		m_pParent->onOpProcess(m_Instance, m_pHostChan->no(), pAssoChan->no(), pAssoChan->type(), m_CallerNum, m_DestNumber);
		if (m_RingTime.empty())
			m_RingTime = Util::CurTime();
		m_Callid = pAssoChan->sessionId();
		auto pSession = CFsProxy::GetInstance().getSession(m_Callid);
		if (pSession != nullptr)
		{
			pSession->ringTime() = m_RingTime;
		}
		pAssoChan->isInMeeting() = true;
	}
	break;
	case CHAN_LOGIC_STATE_TALKING: // 2023-05-09 第三个人成功之后，关联的外线/第一条线路
		if (m_Step == 1) {
			if (!CFsProxy::GetInstance().transfer2Context(uniqueId(), m_pHostChan->chanId(), m_MeetingId, CConfig::GetInstance()->meetingContext(), true)){
				_end(false);
			}
			else {
				m_Step = 2;
			}
		}
		else if(m_Step == 6) { // 3人以上的人 , 成功之后静音第一个人，等待接回
			pAssoChan->isInMeeting() = true;
			CFsProxy::GetInstance().setConferenceExitSound(m_MeetingId, true);
			CFsProxy::GetInstance().setConferenceIsMute(-1, m_MeetingId, m_memberId, true);
			_end(true);
		}
		break;
	case CHAN_LOGIC_STATE_FREE:
		_end(false);
	}
}

void COpMultiMeeting::_end(bool IsSucceed)
{
	if (IsSucceed)
	{
		LOG_INFO(("{OpMultiMeeting}: 分机[%lu]执行会议成功, DestNum = %s"), m_pHostChan->no(), m_DestNumber.c_str());
		m_AnswerTime = Util::CurTime();
		auto pSession = CFsProxy::GetInstance().getSession(m_Callid);
		if (pSession != nullptr)
		{
			pSession->answerTime() = m_AnswerTime;
		}
	}
	else
	{
		LOG_WARN(("{OpMultiMeeting}: 分机[%lu]执行会议失败, DestNum = %s"), m_pHostChan->no(), m_DestNumber.c_str());
	}

	Format fmt("update rep_conference set chanid = '%s', is_success = %d,end_time = '%s' where uuid = '%s' and caller = '%s' and callee = '%s'");
	fmt %m_Callid %IsSucceed %Util::CurTime() % m_MeetingId %m_CallerNum %m_DestNumber;
	SqlWrite::GetInstance()->addSql(fmt.str());

	SqlWrite::GetInstance()->addSql(toSql(IsSucceed, "多步会议"));

	// 返回执行结果
	if (m_InstanceCancel != FS_LINK_INSTANCE_INVALID)
		m_pParent->onOpResult(m_InstanceCancel, !IsSucceed);

	m_pParent->onOpResult(m_Instance, this, IsSucceed, std::to_string(m_pHostChan->no()), m_IsTakeBack ? "MultiTakeback" : "MultiMeeting");
}