midware_ws/NetLib/ACD/AcdCore.h

/*************************************************************************
【文件名】				AcdCore.h
【功能模块和目的】		ACD系统核心控制类头文件
【开发者及日期】		郑石诺 2015/01/20
【版本】				V1.0.0
【版权信息】			Copyright (C)2015 河南加一信息技术有限公司
【更改记录】        
*************************************************************************/
#pragma once

#include "ExtenCtrl.h"
#include "AgentOffice.h"
#include "QueueMgr.h"
#include "SubjectRepository.h"
#include "SoftAuther.h"
#include <set>
typedef struct tagGroupTalking {
	CString groupId;
	std::set<UINT> exts;
	int count() { return exts.size(); }
	void add(UINT extID) {
		exts.emplace(extID);
	}
	void del(UINT extID) {
		auto it = exts.find(extID);
		if (it != exts.end())
			exts.erase(it);
	}
}GroupTalking;

class CAgent;
class CExten;
/*************************************************************************
【类名】				CAcdCore
【功能】				
【接口说明】			ACD系统核心控制类
【开发者及日期】		郑石诺 2015/01/20
【版本】				V1.0.0
【版权信息】			Copyright (C)2015 河南加一信息技术有限公司
【更改记录】        
*************************************************************************/
class CAcdCore : public IMsgObserver
{
	SINGLETON_DECLARE(CAcdCore)

public:	
	~CAcdCore(void);

	bool stage1Start(void);					// ACD一阶段启动
	bool stage2Start(void);					// ACD二阶段启动
	void exit(void);						// ACD系统退出

	void reloadAuther();            //授权刷新

	CExtenCtrl&	getExtenCtrl(void)		{ return m_ExtenCtrl; }
	CAgentOffice& getAgentOffice(void)	{ return m_AgentOffice; }
	CQueueMgr& getQueueMgr(void)		{ return m_QueueMgr; }	

	// 事件响应
	void onNetCtiLinkDown();    // cti断开后续处理 2022-11-03
	void onNetHpServerLinkDown();  // HpServer断开后续处理 2022-11-03
	void onNetLinkDown(PduLinkContent linkContent);						// 连接断开后续处理
	void onRecvCommand(CPduEntity* a_pPduEntity);						// PDU命令到达事件处理

	// 继承自IMsgObserver
	void onMessage(UINT MsgType, const PARAM lpContent);

private:
	CAcdCore(void);

	void __onAgentStateUpdated(UINT AgentId);							// 座席状态变化事件响应
	void __onPhoneStateUpdated(UINT ExtenId);							// 分机状态变化事件响应
	void __onQueueStateUpdated(UINT QueueNo);							// 排队状态变化事件响应
	void __removeAgent(UINT AgentId, UINT ExtId, UINT HostAgent);		// 关闭指定座席

	// 网络命令相关
	void __onCmdAgentReg(CPduEntity* a_pCmd);			// 座席注册
	void __onCmdAgentDial(CPduEntity* a_pCmd);			// 与呼叫相关的命令
	void __onCmdAgentLogin(CPduEntity* a_pCmd);			// 座席签入
	void __onCmdAgentLogout(CPduEntity* a_pCmd);		// 座席签出
	void __onCmdAgentSetState(CPduEntity* a_pCmd);		// 主动设置座席状态
	void __onCmdAgentSubscribe(CPduEntity* a_pCmd);		// 订阅管理
	void __onCmdAgentForceLogout(CPduEntity* a_pCmd);	// 强制签出
	void __onCmdAgentMonControl(CPduEntity* a_pCmd);	// 班长电话控制
	void __onCmdAgentForceState(CPduEntity* a_pCmd);	// 强制座席状态控制
	void __onCmdCtiExtenInfo(CPduEntity* a_pCmd);		// 内线分机状态变化
	void __onCmdCtiRecord(CPduEntity* a_pCmd);			// CTI通知座席录音信息
	void __onCmdCtiDevCall(CPduEntity* a_pCmd);			// CTI通知座席物理外呼
	void __onCmdCtiTrunkUsage(CPduEntity* a_pCmd);		// CTI通知呼叫任务中继利用率
	void __onCmdIvrQueue(CPduEntity* a_pCmd);			// 排队管理
	void __onCmdNeed2Forward(CPduEntity* a_pCmd);		// 只需转发的命令

	void __onCmdDataSendToAgent(CPduEntity* a_pCmd);      //向Agent转发当前通话中继线路数量

	void __onCmdGetAgentList(CPduEntity* a_pCmd);      // 获取坐席列表

	void __onCmdMonitor(CPduEntity* a_pCmd);             // ych 2018.6.4 商丘监控添加命令

	void __onCmdAgentDetail(CPduEntity* a_pCmd);         // 安阳 坐席详情
	void __onCmdUpdateAgentCount();                     // 更新当前签入坐席数量，正在通话数量
	void __onCmdAgentTransferSkillGroup(CPduEntity* a_pCmd);  // 按技能组转移

	void __onCmdAgentSkillGroupWaitCount();   // 每个技能组的排队数量情况

	//
	void __onCallInAgent(CPduEntity* a_pCmd);

private:
	CExtenCtrl m_ExtenCtrl;                         // 内线分机管理类
	CAgentOffice m_AgentOffice;						// 座席管理类
	CQueueMgr m_QueueMgr;							// 来电排队管理类
	CSubjectRepository m_SubjectRepository;			// 发布主题管理类

	SoftAuther m_Auther;                 //授权

	int m_ExtCallOutCount = 0;   // 外呼数量
	int m_TrunkCount = 0;        // 中继呼入数量
	int m_WaitCount =0;          // 当前排队数量  
	int m_LoginCount = 0;        // 当前签入数量
	int m_TalkingCount = 0;      // 当前通话数量 
	int AgentSpeakCount = 0;     // 当前通话数量
	int AgentOnlineCount = 0;    // 坐席在线/签入数量
	int AgentReposeCount = 0;    // 当前置忙坐席数量
	int AgentFreeCount = 0;      // 当前空闲坐席数量
	int AgentProcessingCount = 0; // 当前话后处理坐席数量
	int AgentRingCount = 0;       // 当前振铃坐席数量
};