1

CTI/CTI.cpp

@@ -52,7 +52,7 @@ BOOL CCTIApp::InitInstance()
 #ifndef _DEBUG
 	SetErrorMode(SEM_FAILCRITICALERRORS | SEM_NOGPFAULTERRORBOX);
 #endif
-
+	
 	// 禁止多个实例的同时运行
 	HANDLE hMutexOneInstance = ::CreateMutex(NULL, TRUE, _T(AfxGetAppName()));
 	if (::GetLastError() == ERROR_ALREADY_EXISTS)

CTI/CTI.vcxproj

@@ -81,9 +81,9 @@
       <FunctionLevelLinking>true</FunctionLevelLinking>
       <IntrinsicFunctions>true</IntrinsicFunctions>
       <PreprocessorDefinitions>WIN32;_WINDOWS;NDEBUG;%(PreprocessorDefinitions)</PreprocessorDefinitions>
-      <AdditionalIncludeDirectories>../3rd/hybase/;../Public/GlobalDef/;../Public/DingDing;%(AdditionalIncludeDirectories)</AdditionalIncludeDirectories>
+      <AdditionalIncludeDirectories>../3rd/hybase/;../Public/GlobalDef/;../Public/DingDing;../Public/dump;%(AdditionalIncludeDirectories)</AdditionalIncludeDirectories>
       <LanguageStandard>stdcpp14</LanguageStandard>
-      <SDLCheck>true</SDLCheck>
+      <SDLCheck>false</SDLCheck>
     </ClCompile>
     <Link>
       <SubSystem>Windows</SubSystem>

CTI/TaskMgr.cpp

@@ -21,10 +21,10 @@ CTaskMgr::~CTaskMgr(void)
 /*****************************************************************
 **【函数名称】	__addTask
 **【函数功能】	 添加Task
-**【参数】		
+**【参数】
 **【返回值】
 ****************************************************************/
-void CTaskMgr::__addTask( CTask* pTask )
+void CTaskMgr::__addTask(CTask* pTask)
 {
 	m_TaskLock.Lock();
 	m_TaskTable.SetAt(reinterpret_cast<LONG>(pTask), pTask);
@@ -35,21 +35,21 @@ void CTaskMgr::__addTask( CTask* pTask )
 **【函数名称】	__onAgentLogin
 **【函数功能】	坐席签入处理
 **【参数】		消息实体
-**【返回值】	
+**【返回值】
 ****************************************************************/
-void CTaskMgr::__onAgentLogin( CPduEntity &PduEntity )
+void CTaskMgr::__onAgentLogin(CPduEntity &PduEntity)
 {
 	// 显示日志
 	ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_NORMAL, _T("Agent->CTI, CMD = [坐席签入], \
 													  Exten = %d, Agent = %d"),
-													  PduEntity.GetDataUInt(1),
-													  PduEntity.GetDataUInt(2));
+		PduEntity.GetDataUInt(1),
+		PduEntity.GetDataUInt(2));
 
 	// 设置内线分机的当前坐席工号
 	CLogicLine* pLine = CLineHolder::GetInstance().getLogicLine(PduEntity.GetDataUInt(1));
-	if(pLine == NULL) 
+	if (pLine == NULL)
 		ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_WARNING, _T("{TaskMgr}: 坐席[%d]签入绑定分机失败: 无法获取目标分机[%d]"), PduEntity.GetDataUInt(2),
-									PduEntity.GetDataUInt(1));
+			PduEntity.GetDataUInt(1));
 	else
 		pLine->setAgentNum(PduEntity.GetDataUInt(2), PduEntity.GetDataString(3));
 }
@@ -58,35 +58,35 @@ void CTaskMgr::__onAgentLogin( CPduEntity &PduEntity )
 **【函数名称】	__onAgentLogout
 **【函数功能】	坐席签出处理
 **【参数】		消息实体
-**【返回值】	
+**【返回值】
 ****************************************************************/
-void CTaskMgr::__onAgentLogout( CPduEntity &PduEntity )
+void CTaskMgr::__onAgentLogout(CPduEntity &PduEntity)
 {
 	// 显示日志
-	ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_NORMAL, _T("Agent->CTI, CMD = [坐席签出], Exten = %d, Agent = %d"), 
-													  PduEntity.GetDataUInt(1),
-													  PduEntity.GetDataUInt(2));
+	ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_NORMAL, _T("Agent->CTI, CMD = [坐席签出], Exten = %d, Agent = %d"),
+		PduEntity.GetDataUInt(1),
+		PduEntity.GetDataUInt(2));
 
 	// 设置内线分机的当前坐席工号
 	CLogicLine* pLine = CLineHolder::GetInstance().getLogicLine(PduEntity.GetDataUInt(1));
-	if(pLine != NULL) 
-		pLine->setAgentNum(0,"");
+	if (pLine != NULL)
+		pLine->setAgentNum(0, "");
 }
 
 /*****************************************************************
 **【函数名称】	__onAgentReset
 **【函数功能】	重置处理
 **【参数】		消息实体
-**【返回值】	
+**【返回值】
 ****************************************************************/
-void CTaskMgr::__onAgentReset( CPduEntity &PduEntity )
+void CTaskMgr::__onAgentReset(CPduEntity &PduEntity)
 {
 	// 显示日志
 	ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_NORMAL, _T("Agent->CTI, CMD = [坐席重置], Exten = %d"), PduEntity.GetDataUInt(1));
 
 	// 获取线路类指针
 	CLogicLine* pLine = CLineHolder::GetInstance().getLogicLine(PduEntity.GetDataUInt(1));
-	if(pLine == NULL) 
+	if (pLine == NULL)
 		return;
 
 	// 删除关联任务
@@ -100,14 +100,14 @@ void CTaskMgr::__onAgentReset( CPduEntity &PduEntity )
 **【函数名称】	__onTaskFailed
 **【函数功能】	处理Task执行失败
 **【参数】		消息实体
-**【返回值】	
+**【返回值】
 ****************************************************************/
-void CTaskMgr::__onTaskFailed( CTask* pTask, CPduEntity &PduEntity )
+void CTaskMgr::__onTaskFailed(CTask* pTask, CPduEntity &PduEntity)
 {
 	// 显示日志
 	CString DevType;
 	UINT HostLine;
-	if(PduEntity.GetLocalDevType() == PDU_DEV_TYPE_ACD)
+	if (PduEntity.GetLocalDevType() == PDU_DEV_TYPE_ACD)
 	{
 		DevType = _T("ACD");
 		HostLine = PduEntity.GetDataUInt(1);
@@ -133,14 +133,14 @@ void CTaskMgr::__onTaskFailed( CTask* pTask, CPduEntity &PduEntity )
 **【函数功能】	处理设备操作进展
 **【参数】		EvtType 消息事件类型
 				lpContent 消息内容
-**【返回值】		
+**【返回值】
 ****************************************************************/
-void CTaskMgr::__procDevOpProcess( UINT EvtType, const PARAM lpContent )
+void CTaskMgr::__procDevOpProcess(UINT EvtType, const PARAM lpContent)
 {
 	EventOpProcess &EvtInfo = *(EventOpProcess*)lpContent;
 	// 查找到Task并处理
 	CTask* pTask = findTask(EvtInfo.nInstance);
-	if(pTask != NULL)		
+	if (pTask != NULL)
 		pTask->OnDevOpProcess(EvtInfo);
 }
 
@@ -149,9 +149,9 @@ void CTaskMgr::__procDevOpProcess( UINT EvtType, const PARAM lpContent )
 **【函数功能】	设备操作结果返回
 **【参数】		EvtType 消息事件类型
 				lpContent 消息内容
-**【返回值】	
+**【返回值】
 ****************************************************************/
-void CTaskMgr::__procDevOpResult( UINT EvtType, const PARAM lpContent )
+void CTaskMgr::__procDevOpResult(UINT EvtType, const PARAM lpContent)
 {
 	__try
 	{
@@ -177,15 +177,15 @@ void CTaskMgr::__procDevOpResult( UINT EvtType, const PARAM lpContent )
 **【函数功能】	设备主动操作
 **【参数】		EvtType 消息事件类型
 				lpContent 消息内容
-**【返回值】		
+**【返回值】
 ****************************************************************/
-void CTaskMgr::__procDevOperator( UINT EvtType, const PARAM lpContent )
+void CTaskMgr::__procDevOperator(UINT EvtType, const PARAM lpContent)
 {
 	CTask *pTask = NULL;
 	// 事件内容解析
 	EventDevOperation &EvtInfo = *(EventDevOperation*)lpContent;
-	
-	switch(EvtInfo.nOpType)
+
+	switch (EvtInfo.nOpType)
 	{
 	case DEV_OP_CALL_IN:				// 外线来电
 		pTask = new(std::nothrow) CTaskDevCallIn(EvtInfo);
@@ -199,24 +199,24 @@ void CTaskMgr::__procDevOperator( UINT EvtType, const PARAM lpContent )
 		break;
 	}
 
-	if(pTask == NULL) 
+	if (pTask == NULL)
 		return;
 
 	// 保存Task
 	__addTask(pTask);
 
 	// 返回Fals代表执行失败，移除Task
-	if(!pTask->DoTask()) 
-		removeTask((long)pTask);	
+	if (!pTask->DoTask())
+		removeTask((long)pTask);
 }
 
 /*****************************************************************
 **【函数名称】	init
 **【函数功能】	模块初始化
-**【参数】		
-**【返回值】	
+**【参数】
+**【返回值】
 ****************************************************************/
-void CTaskMgr::init( void )
+void CTaskMgr::init(void)
 {
 	// 注册底层设备消息和设备操作结果
 	CMsgCenter& MC = CMsgCenter::GetInstance();
@@ -237,24 +237,24 @@ void CTaskMgr::uninit(void)
 /*****************************************************************
 **【函数名称】	removeTask
 **【函数功能】	删除Task
-**【参数】		
-**【返回值】	
+**【参数】
+**【返回值】
 ****************************************************************/
-void CTaskMgr::removeTask( long TaskId )
+void CTaskMgr::removeTask(long TaskId)
 {
-	if(TaskId == TASK_ID_INVALID)
+	if (TaskId == TASK_ID_INVALID)
 		return;
 
 	m_TaskLock.Lock();
 
 	CTask* pTask = NULL;
-	if(m_TaskTable.Lookup(TaskId, pTask))
+	if (m_TaskTable.Lookup(TaskId, pTask))
 	{
 		m_TaskTable.RemoveKey(TaskId);
 		// 删除Task	
 		ASSERT(pTask != NULL);
 		delete pTask;
-		pTask=NULL;
+		pTask = NULL;
 	}
 
 	POSITION pos = m_TaskTable.GetStartPosition();
@@ -264,7 +264,7 @@ void CTaskMgr::removeTask( long TaskId )
 		if (pTask == NULL || pTask->IsExpire()) {
 			m_TaskTable.RemoveKey(strKey);
 			if (pTask != NULL) {
-				ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_ERROR, _T("{TaskMgr}: 失效Task[%s]TaskId[%ld]LineId[%d]时间[%ld]删除"),pTask->Name(), reinterpret_cast<LONG>(pTask),pTask->GetAssoLineId(),pTask->TaskTime());
+				ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_ERROR, _T("{TaskMgr}: 失效Task[%s]TaskId[%ld]LineId[%d]时间[%ld]删除"), pTask->Name(), reinterpret_cast<LONG>(pTask), pTask->GetAssoLineId(), pTask->TaskTime());
 				delete pTask;
 				pTask = NULL;
 			}
@@ -281,12 +281,12 @@ void CTaskMgr::removeTask( long TaskId )
 /*****************************************************************
 **【函数名称】	findTask
 **【函数功能】	查找Task
-**【参数】		
+**【参数】
 **【返回值】
 ****************************************************************/
-CTask* CTaskMgr::findTask( long TaskId )
+CTask* CTaskMgr::findTask(long TaskId)
 {
-	if(TaskId == TASK_ID_INVALID)
+	if (TaskId == TASK_ID_INVALID)
 		return NULL;
 
 	CTask* pTask = NULL;
@@ -302,14 +302,14 @@ CTask* CTaskMgr::findTask( long TaskId )
 **【函数名称】	onPduMessage
 **【函数功能】	Pdu命令处理接口
 **【参数】		PduEntity: 消息实体
-**【返回值】	
+**【返回值】
 ***************************************************************/
-void CTaskMgr::onPduMessage( CPduEntity &PduEntity )
+void CTaskMgr::onPduMessage(CPduEntity &PduEntity)
 {
 	// 根据命令类型创建Task
 	CTask *pTask = NULL;
 	PDU_CMD_TYPE nCmdType = PduEntity.GetCmdType();
-	switch(nCmdType)
+	switch (nCmdType)
 	{
 	case PDU_CMD_AGENT_LOGIN:			// 坐席签入
 		__onAgentLogin(PduEntity);
@@ -344,7 +344,7 @@ void CTaskMgr::onPduMessage( CPduEntity &PduEntity )
 		break;
 
 	case PDU_CMD_AGENT_TAKEBACK:		// 坐席接回
-		pTask = new(std::nothrow) CTaskAgentTakeBack(PduEntity);	
+		pTask = new(std::nothrow) CTaskAgentTakeBack(PduEntity);
 		break;
 
 	case PDU_CMD_AGENT_TRANSTALK:		// 坐席转移
@@ -435,17 +435,14 @@ void CTaskMgr::onPduMessage( CPduEntity &PduEntity )
 		break;
 	}
 
-	if(pTask == NULL) return;
+	if (pTask == NULL) return;
 
 	// 保存Task
 	__addTask(pTask);
 
 	// 返回Fase代表操作失败，移除该Task
-	if(!pTask->DoTask()) 
+	if (!pTask->DoTask())
 		__onTaskFailed(pTask, PduEntity);
-	else
-		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_NORMAL, _T("{CTaskMgr}:DoTask[%s]TaskId[%ld]LineId[%d]时间[%ld]"), pTask->Name(), reinterpret_cast<LONG>(pTask), pTask->GetAssoLineId(), pTask->TaskTime());
-
 }
 
 /*****************************************************************
@@ -455,21 +452,21 @@ void CTaskMgr::onPduMessage( CPduEntity &PduEntity )
 				PduEntity：消息实体
 **【返回值】
 ***************************************************************/
-void CTaskMgr::onTaskPduMsg( UINT LineId, CPduEntity &PduEntity )
+void CTaskMgr::onTaskPduMsg(UINT LineId, CPduEntity &PduEntity)
 {
 	CLogicLine* pLine = CLineHolder::GetInstance().getLogicLine(LineId);
 	ASSERT(pLine != NULL);
-	if(pLine == NULL)
+	if (pLine == NULL)
 	{
 		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{TaskMgr}: Task处理PDU命令失败, 无法定位关联线路[%d]"), LineId);
 		return;
 	}
 
 	CTask* pTask = findTask(pLine->taskIdBinded());
-	if(pTask == NULL)
+	if (pTask == NULL)
 	{
 		pLine->taskIdBinded() = TASK_ID_INVALID;
-		if(PduEntity.GetCmdType() == PDU_CMD_AGENT_CONFIRM_TRANSFER)
+		if (PduEntity.GetCmdType() == PDU_CMD_AGENT_CONFIRM_TRANSFER)
 		{
 			// 返回命令
 			PduEntity.SetToExecReturn();
@@ -480,8 +477,8 @@ void CTaskMgr::onTaskPduMsg( UINT LineId, CPduEntity &PduEntity )
 	else
 	{
 		// task处理Pdu命令返回成功，删除task
-		if(pTask->OnCmdOperation(PduEntity))
-			removeTask((long)pTask); 
+		if (pTask->OnCmdOperation(PduEntity))
+			removeTask((long)pTask);
 	}
 }
 
@@ -490,13 +487,13 @@ void CTaskMgr::onTaskPduMsg( UINT LineId, CPduEntity &PduEntity )
 **【函数功能】	消息事件处理函数
 **【参数】		EvtType 消息事件类型
 				lpContent 消息内容
-**【返回值】	
+**【返回值】
 ****************************************************************/
-void CTaskMgr::onMessage( UINT MsgType, const PARAM lpContent )
+void CTaskMgr::onMessage(UINT MsgType, const PARAM lpContent)
 {
-	if(lpContent == NULL) return;
+	if (lpContent == NULL) return;
 
-	switch(MsgType)
+	switch (MsgType)
 	{
 	case DEV_EVENT_LINE_OP_PROCESS:		// 设备操作进展
 		__procDevOpProcess(MsgType, lpContent);
@@ -513,10 +510,3 @@ void CTaskMgr::onMessage( UINT MsgType, const PARAM lpContent )
 }
 
 
-
-
-
-
-
-
-

IVR/DingDing.yml

@@ -0,0 +1,5 @@
+IsPush: false
+PushUrl: https://oapi.dingtalk.com/robot/send?access_token=d4efe5b71f2e92a11ff89bb8ad704319e2d874ef5e590e8a78247405542bf637
+ProjectName: "[127.0.0.1-UNKNOW]"
+HeartTimeOut: 2
+DelayTime: 0

IVR/NetworkIvr.cpp

@@ -30,7 +30,7 @@ BOOL CNetworkIvr::init( void )
 #else
 	CPduDataFormat::getInstance()->Load("./PDUFormat.ini");
 #endif
-
+	/*
 	// 注册事件响应接口
 	IPduLink* pPduLink = CInterfaceWindow::getLinkInstance();
 	IPduComm* pPduComm = CInterfaceWindow::getCommInstance();
@@ -45,7 +45,25 @@ BOOL CNetworkIvr::init( void )
 		ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_ERROR, _T("{Network}: 连接CTI服务器[%s:%d]失败, 请检查网络配置是否正常"), CtiIp, CtiPort);
 		return FALSE;
 	} // end if
+	*/
+	// 注册事件响应接口 2022-10-26 改用IOCP,保持和CTI,ACD一样
+	CInterfaceWindow::getIocpLinkInstance()->RegistPduLinkProc(this, TRUE);
+	CInterfaceWindow::getIocpCommInstance()->RegistPduCommProc(this, TRUE);
+	CString CtiIp = CConfig::ctiIp();
+	int CtiPort = CConfig::ctiPort();
+	// 创建 SERVER
+	int ListenPort = 8841;
+	if (!CInterfaceWindow::getIocpLinkInstance()->CreatePduServer(ListenPort, PDU_DEV_TYPE_IVR, 0))
+	{
+		ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_ERROR, _T("{Network}: 连接CTI服务器[%s:%d]失败, 请检查端口[%d]是否被占用"), CtiIp, CtiPort, ListenPort);
+		return false;
+	}
 
+	if (!CInterfaceWindow::getIocpLinkInstance()->CreatePduClient(CtiIp, CtiPort, PDU_DEV_TYPE_IVR, 0, PDU_DEV_TYPE_CTI, 0, true))
+	{
+		ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_ERROR, _T("{Network}: 连接CTI服务器[%s:%d]失败, 请检查网络配置是否正常"), CtiIp, CtiPort);
+		return false;
+	} // end if
 	return TRUE;
 }
 
@@ -66,17 +84,23 @@ void CNetworkIvr::release( void )
 **【参数】		设备类型，命令内容
 **【返回值】	
 ****************************************************************/
-BOOL CNetworkIvr::send( CPduEntity& a_PduEntity )
+BOOL CNetworkIvr::send(CPduEntity& a_PduEntity)
 {
-	if(!m_IsCtiConnected) 
+	if (!m_IsCtiConnected)
 		return false;
-
+	/*
 	// 判断是返回消息还是主动给CTI的消息
 	IPduComm* pComm = CInterfaceWindow::getCommInstance();
 	if(a_PduEntity.GetIsExecReturn())
 		return pComm->Send(&a_PduEntity, a_PduEntity.GetLocalDevType(), a_PduEntity.GetLocalDevId());
 
 	return pComm->Send(&a_PduEntity, PDU_DEV_TYPE_CTI, m_CtiDevID);
+	*/
+	// 判断是返回消息还是主动给CTI的消息 2022-10-26 改用iocp，保持和CTI,ACD一样
+	auto pComm = CInterfaceWindow::getIocpCommInstance();
+	if (a_PduEntity.GetIsExecReturn())
+		pComm->Send(&a_PduEntity, a_PduEntity.GetLocalDevType(), a_PduEntity.GetLocalDevId());
+	return pComm->Send(&a_PduEntity, PDU_DEV_TYPE_CTI, m_CtiDevID);
 }
 
 /*****************************************************************

IVR/RcfConfig.yml

@@ -0,0 +1,10 @@
+Rcf:
+  IP: 127.0.0.1
+  PORT: 5001
+Redis:
+  IP: 127.0.0.1
+  PORT: 6379
+Http:
+  PORT: 8000
+Https:
+  PORT: 8443

IVR/log/2022-10-11/IVR_1.txt

@@ -0,0 +1,44 @@
+2022-10-11 17:33:55.714960 | 2022-10-11 17:33:55.714960 [信息] CPduSocket::OnReceive(266)接收[CTI]数据长度[28]
+2022-10-11 17:33:55.714960 | 2022-10-11 17:33:55.714960 [信息] CPduSocket::OnReceive(268)待处理[CTI]数据长度[28]
+2022-10-11 17:33:55.714960 | 2022-10-11 17:33:55.714960 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[0]
+2022-10-11 17:33:55.714960 | 2022-10-11 17:33:55.714960 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:34:20.569541 | 2022-10-11 17:34:20.568538 [信息] CPduSocket::OnReceive(266)接收[CTI]数据长度[28]
+2022-10-11 17:34:20.569541 | 2022-10-11 17:34:20.569541 [信息] CPduSocket::OnReceive(268)待处理[CTI]数据长度[28]
+2022-10-11 17:34:20.569541 | 2022-10-11 17:34:20.569541 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[0]
+2022-10-11 17:34:20.570505 | 2022-10-11 17:34:20.569541 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:44:12.614197 | 2022-10-11 17:43:58.904851 [信息] CPduSocket::OnReceive(266)接收[CTI]数据长度[106]
+2022-10-11 17:44:31.375037 | 2022-10-11 17:44:02.508216 [信息] CPduSocket::OnReceive(268)待处理[CTI]数据长度[106]
+2022-10-11 17:46:08.476424 | 2022-10-11 17:44:31.375037 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[78]
+2022-10-11 17:47:00.848399 | 2022-10-11 17:46:39.239175 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:47:02.116011 | 2022-10-11 17:47:00.848399 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[52]
+2022-10-11 17:47:09.010577 | 2022-10-11 17:47:02.111024 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:47:57.494948 | 2022-10-11 17:47:57.489961 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[26]
+2022-10-11 17:47:59.532500 | 2022-10-11 17:47:59.529508 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:49:56.263970 | 2022-10-11 17:49:54.134662 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[0]
+2022-10-11 17:49:56.263970 | 2022-10-11 17:49:54.134662 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:49:56.263970 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(266)接收[CTI]数据长度[312]
+2022-10-11 17:49:56.263970 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(268)待处理[CTI]数据长度[312]
+2022-10-11 17:49:56.263970 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[286]
+2022-10-11 17:49:56.263970 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:49:56.263970 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[260]
+2022-10-11 17:49:56.263970 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:49:56.263970 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[234]
+2022-10-11 17:49:56.263970 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:49:56.263970 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[208]
+2022-10-11 17:49:56.263970 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:49:56.264967 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[182]
+2022-10-11 17:49:56.264967 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:49:56.264967 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[156]
+2022-10-11 17:49:56.264967 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:49:56.264967 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[130]
+2022-10-11 17:49:56.264967 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:49:56.264967 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[104]
+2022-10-11 17:49:56.264967 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:49:56.264967 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[78]
+2022-10-11 17:49:56.264967 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:49:56.264967 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[52]
+2022-10-11 17:49:56.264967 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:49:56.264967 | 2022-10-11 17:49:56.263970 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[26]
+2022-10-11 17:49:56.264967 | 2022-10-11 17:49:56.264967 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据
+2022-10-11 17:49:56.264967 | 2022-10-11 17:49:56.264967 [信息] CPduSocket::OnReceive(298)准备提交[CTI]数据[0]
+2022-10-11 17:49:56.264967 | 2022-10-11 17:49:56.264967 [信息] CPduSocket::OnReceive(300)已处理[CTI]提交数据

Middleware.sln

@@ -23,6 +23,8 @@ Project("{8BC9CEB8-8B4A-11D0-8D11-00A0C91BC942}") = "FsLink", "FsLink\FsLink.vcx
 EndProject
 Project("{8BC9CEB8-8B4A-11D0-8D11-00A0C91BC942}") = "DBCtrl", "DBCtrl\DBCtrl.vcxproj", "{BBC31C4F-52DF-43EC-93AC-BE95DBA71180}"
 EndProject
+Project("{8BC9CEB8-8B4A-11D0-8D11-00A0C91BC942}") = "NetLib", "NetLib\NetLib.vcxproj", "{2393D53B-07E9-4D90-9B10-0707E065C2D6}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Win32 = Debug|Win32
@@ -91,6 +93,12 @@ Global
 		{BBC31C4F-52DF-43EC-93AC-BE95DBA71180}.Release|Win32.ActiveCfg = Release|Win32
 		{BBC31C4F-52DF-43EC-93AC-BE95DBA71180}.Release|Win32.Build.0 = Release|Win32
 		{BBC31C4F-52DF-43EC-93AC-BE95DBA71180}.Release|x64.ActiveCfg = Release|Win32
+		{2393D53B-07E9-4D90-9B10-0707E065C2D6}.Debug|Win32.ActiveCfg = Debug|Win32
+		{2393D53B-07E9-4D90-9B10-0707E065C2D6}.Debug|Win32.Build.0 = Debug|Win32
+		{2393D53B-07E9-4D90-9B10-0707E065C2D6}.Debug|x64.ActiveCfg = Debug|Win32
+		{2393D53B-07E9-4D90-9B10-0707E065C2D6}.Release|Win32.ActiveCfg = Release|Win32
+		{2393D53B-07E9-4D90-9B10-0707E065C2D6}.Release|Win32.Build.0 = Release|Win32
+		{2393D53B-07E9-4D90-9B10-0707E065C2D6}.Release|x64.ActiveCfg = Release|Win32
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

Public/GlobalDef/SqlWriter.cpp

@@ -65,19 +65,21 @@ UINT CSqlWriter::__writeThreadFun( LPVOID pParam )
 			{
 				ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_ERROR, _T("{SQL}: 统计信息写入数据库失败，统计内容：%s"), Sql);
 				ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_ERROR, _T("{SQL}: 统计写入数据库失败原因：%s"), pDbControl->GetLastError());
-			   
+				bool isSuccess = false;
 				for (int i = 0; i < 5; ++i)
 				{
 					Sleep(1000 * 2);
 					if (pDbControl->ExecCommand(Sql))
 					{
+						isSuccess = true;
 						ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_ERROR, _T("{SQL}: 统计信息再次写入数据库成功，统计内容：%s"), Sql);
 						break;
 					}
 				}
-				ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_ERROR, _T("{SQL}: 统计信息再次写入数据库失败，统计内容：%s"), Sql);
-				ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_ERROR, _T("{SQL}: 统计再次写入数据库失败原因：%s"), pDbControl->GetLastError());
-
+				if (!isSuccess) {
+					ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_ERROR, _T("{SQL}: 统计信息再次写入数据库失败，统计内容：%s"), Sql);
+					ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_ERROR, _T("{SQL}: 统计再次写入数据库失败原因：%s"), pDbControl->GetLastError());
+				}
 			}
 
 		} // end while

Release/PDUFormat.ini

@@ -18,7 +18,7 @@
 
 ;综合信息
 [Head]
-TotalCount = 65					// 命令总数
+TotalCount = 66					// 命令总数
 
 ;注册[PDU_CMD_REG]
 [PDU_CMD_FORMAT_000]
@@ -36,7 +36,7 @@ DataCount = 0;
 ;坐席签入[PDU_CMD_AGENT_LOGIN]
 [PDU_CMD_FORMAT_002]
 CmdType = 101
-DataCount = 8
+DataCount = 9
 DATA[0] = 4|0|操作是否成功|1
 DATA[1] = 1|0|坐席分机ID|0
 DATA[2] = 1|0|坐席工号|0
@@ -45,6 +45,7 @@ DATA[4] = 1|0|
 DATA[5] = 1|0|话后处理时长|0
 DATA[6] = 1|0|签入失败原因|1
 DATA[7] = 1|0|坐席媒体编码|1
+DATA[8] = 1|0|是否恢复签入|0
 
 ;坐席签出[PDU_CMD_AGENT_LOGOUT]
 [PDU_CMD_FORMAT_003]
@@ -381,14 +382,13 @@ DATA[1] = 1|0|占
 ;CTI通知IVR外线来电[PDU_CMD_CTI_IVR_CALLIN]
 [PDU_CMD_FORMAT_036]
 CmdType = 306
-DataCount = 7
+DataCount = 6
 DATA[0] = 4|0|IVR处理来电结果|1
 DATA[1] = 0|0|流程ID|1
 DATA[2] = 3|0|CallID|0
 DATA[3] = 5|64|主叫号码|0
 DATA[4] = 5|64|被叫号码|0
 DATA[5] = 1|0|外线ID|0
-DATA[6] = 5|64|fsUUID|0
 
 ;CTI通知IVR转IVR[PDU_CMD_CTI_IVR_TURNIVR]
 [PDU_CMD_FORMAT_037]
@@ -686,3 +686,11 @@ DATA[0] = 4|0|
 DATA[1] = 1|0|坐席分机ID|0
 DATA[2] = 1|0|坐席工号|0
 DATA[3] = 5|256|按键内容|0
+
+;请求分机状态列表，驻马店专用[PDU_CMD_EXTEN_STATE_LIST_ZMD]
+[PDU_CMD_FORMAT_065]
+CmdType = 146
+DataCount = 2
+DATA[0] = 1|0|坐席分机ID|0
+DATA[1] = 1|0|坐席工号|0
+

Release/sql脚本.txt

@@ -0,0 +1,54 @@
+--判断字段不存在则添加
+if not exists(select * from sys.columns where name='GroupId' and [object_id]=object_id(N'rep_ext_call_in')) 
+alter table rep_ext_call_in add GroupId varchar(64) null
+
+if not exists(select * from sys.columns where name='GroupId' and [object_id]=object_id(N'rep_ext_call_out')) 
+alter table rep_ext_call_out add GroupId varchar(64) null
+
+if not exists(select * from sys.columns where name='GroupId' and [object_id]=object_id(N'rep_agent_state')) 
+alter table rep_agent_state add GroupId varchar(64) null
+
+if not exists(select * from sys.columns where name='ExtId' and [object_id]=object_id(N'rep_agent_state')) 
+alter table rep_agent_state add ExtId int null
+
+--新增表
+if not exists (select * from sysobjects where id = object_id('rep_service') 
+and OBJECTPROPERTY(id, 'IsUserTable') = 1) begin
+create table  rep_service(
+   Checkin int,
+   Conversation int 
+)end
+
+if not exists (select * from sysobjects where id = object_id('rep_wait_count') 
+and OBJECTPROPERTY(id, 'IsUserTable') = 1) begin
+create table  rep_wait_count
+(
+   id int,
+   Count int,
+   UpdateTime datetime ,
+   primary key (id)
+)
+end
+
+if not exists (select * from sysobjects where id = object_id('rep_hangup') 
+and OBJECTPROPERTY(id, 'IsUserTable') = 1) begin
+create table  rep_hangup
+(
+   CallID bigint,
+   HangUpType int,
+   primary key (CallID)
+)
+end
+
+if not exists (select * from sysobjects where id = object_id('rep_freeswitch') 
+and OBJECTPROPERTY(id, 'IsUserTable') = 1) begin
+create table  rep_freeswitch
+(
+   Id int IDENTITY (1, 1) NOT NULL,
+   UUId varchar(50),
+   CallID bigint,
+   CreateTime datetime,
+   HupTime datetime,
+   primary key (Id)
+)
+end