fix: bug

src/core/callcenter/agent.py

@@ -115,6 +115,7 @@ class AgentEventService:
                     return
 
             self.agent_state_service.busy(saas_id, agent.agent_num, agent.phone_num)
+            self.data_handle_server.update_record(call_id, status=1)
             if is_agent:
                 # 坐席接起
                 self.cache.set_call_is_answer(saas_id, flow_id)
@@ -143,6 +144,7 @@ class AgentEventService:
 
             self.agent_actionlog_service.insert_service_state(agent_monitor, AgentServiceState.REPROCESSING, AgentLogState.CHANNEL_HANG_UP)
 
+            self.data_handle_server.update_record(call_id, time_end=datetime.utcnow())
             # 同步处理后处理置闲
             # reprocessingIdle(statusDto);
             # agentProducer.pushDelayedStatus(statusDto, reprocessingTimeout);
@@ -192,6 +194,7 @@ class AgentEventService:
 
         if CHANNEL_ANSWER == event_name:
             self.agent_state_service.busy(saas_id, agent.agent_num, agent.phone_num)
+            self.data_handle_server.update_record(call_id, status=1)
             if is_agent:
                 self.agent_monitor_service.update_calling(agent_monitor)
                 self.push_handler.push_on_agent_work_report(saas_id, flow_id, agent_num, call_id, AgentScene.ROBOT, WorkStatus.AGENT_ANSWER_INCOMING, "座席接通呼入电话! internal")
@@ -210,6 +213,7 @@ class AgentEventService:
 
             self.agent_actionlog_service.insert_service_state(agent_monitor, AgentServiceState.REPROCESSING,
                                                   AgentLogState.CHANNEL_HANG_UP, service_id=human_service_id)
+            self.data_handle_server.update_record(call_id, time_end=datetime.utcnow())
 
 
     def reprocessing_idle(self, state_data: AgentDelayStateData):

src/core/callcenter/call.py

@@ -80,6 +80,7 @@ class CallService:
         self.agent_monitor_service.update_dialing(agent_monitor)
         self.push_handler.push_on_call_ring(call_info.saas_id, flow_id=call_info.cti_flow_id, user_id=agent_id, scene=AgentScene.MANUAL, call_id=call_info.call_id, service_direct=ServiceDirect.MANUAL_CALL.service_direct)
         self.agent_actionlog_service.insert_service_state(agent_monitor, AgentServiceState.DIALING, AgentLogState.DIALING)
+        self.data_handle_server.create_record(call_info.call_id, call_info.called, call_info.call_type, service_category=0, destination=agent_id)
 
     def hold(self, call_info: CallInfo, device_id):
         devices = call_info.device_list

src/core/callcenter/data_handler.py

@@ -9,15 +9,15 @@ class DataHandleServer:
         self.app = app
 
     @with_app_context
-    def create_record(self, call_id, caller_number, call_type, service_category=None, destination=None):
+    def create_record(self, call_id, caller_number, call_type, service_category=None, destination=None, category=0):
         call_info = {
             "session_id": call_id,
             "time_begin": datetime.utcnow(),
-            "category": 0,
+            "category": category,
             "phone": caller_number,
             "type": call_type,
             "service_category": service_category,
-            "agent_num":destination,
+            # "agent_num":destination,
             "user_id":destination,
             "user_name": f"机器人{destination}" if destination else None,
         }
@@ -27,10 +27,9 @@ class DataHandleServer:
             if hasattr(call_record, key):  # 确保模型有这个属性
                 setattr(call_record, key, value)
         try:
-            if call_info.get("type") in [0, 2] or call_info.get("category") == 1:  # 如果呼入类型是白名单和传统服务或者是呼出 修改用户id和用户名称
-                agent_num = call_info.get("agent_num")  # 使用 get 方法
-                if agent_num:  # 确保 agent_num 存在
-                    agent = self.get_user_name(agent_num)
+            if call_type in [0, 2] or category == 1:  # 如果呼入类型是白名单和传统服务或者是呼出修改坐席id和坐席名称
+                if destination:  # 确保 agent_num 存在
+                    agent = self.get_user_name(destination)
                     call_record.user_id = agent.user_id
                     call_record.user_name = agent.agent_name
             db.session.add(call_record)
@@ -41,10 +40,10 @@ class DataHandleServer:
             raise ValueError(f"创建记录失败: {e}")
 
     @with_app_context
-    def update_record(self, session_id, call_info):
+    def update_record(self, session_id, **kwargs):
         call_record = CallRecord.query.filter(CallRecord.session_id == session_id).first()
         # 动态更新字段
-        for key, value in call_info.items():
+        for key, value in kwargs.items():
             if hasattr(call_record, key):
                 setattr(call_record, key, value)
         db.session.commit()
@@ -101,5 +100,5 @@ class DataHandleServer:
     def update_call_record_bussiness_type(self, session):
         BotRecord = BotRecords.query.filter(BotRecords.session == session).first()
         print("BotRecord",BotRecord.intent,session,flush=True)
-        self.update_record(session, {"bussiness_type": BotRecord.intent})
+        self.update_record(session, bussiness_type=BotRecord.intent)
         db.session.commit()

src/core/callcenter/esl/client.py

@@ -178,7 +178,7 @@ class InboundClient:
             #         self.cache.add_delay_message(DelayActionEnum.CALL_TIMEOUT_DECR, delay_action, timeouts=20)
             self.cache.add_call_info(call_info)
             self.hangup_call(call_id, device_id, CallCause.CALL_TIMEOUT)
-            self.dataHandleServer.update_record(call_id, {"status": 0})
+            self.dataHandleServer.update_record(call_id, status= 0)
     def exec_when_play_timeout(self, call_id):
         call_info = self.cache.get_call_info(call_id)
         if not call_info or not call_info.next_commands:
@@ -523,11 +523,13 @@ class OutboundClient:
 
                     _bucket_call_type = 2
                     destination = None
+                    service_category = 0
                     bucket = self.server.get_bucket(call_id)
                     whitelist = self.server.get_whitelist()
                     if bucket and bucket.name == 'AI':
                         #转到ai机器人
                         _bucket_call_type = 1
+                        service_category = 1
                         destination = self.server.agent.register(**kwargs)
                         self.server.logger.info("device_id=%s, destination=%s, new_device_id=%s" % (device_id, destination, new_device_id))
                         self.build_call_info(call_id, device_id, new_device_id, str(destination), bucket_type=_bucket_call_type, **kwargs)
@@ -544,7 +546,7 @@ class OutboundClient:
                         self.server.agent.acd_service.transfer_to_agent(call_id, new_device_id)
 
                     registry.counter('call_incoming_requests', '呼入流量统计', {'bucket_type': f"{_bucket_call_type}"})
-                    self.server.dataHandleServer.create_record(call_id, caller_number, _bucket_call_type, service_category=None, destination=destination)
+                    self.server.dataHandleServer.create_record(call_id, caller_number, _bucket_call_type, service_category=service_category, destination=destination)
 
                     # # 检查白名单
                     # if caller_number in whitelist:

src/core/callcenter/esl/handler/channel_answer_handler.py

@@ -75,7 +75,7 @@ class ChannelAnswerHandler(EslEventHandler):
         record_url = self.record(event, device_id)
         device.record = record_url
         device.record_start_time = device.answer_time
-        self.dataHandleServer.update_record(call_id, {"url": record_url})
+        self.dataHandleServer.update_record(call_id, url= record_url)
 
         call.direction = Direction.OUTBOUND.code
         call.answer_flag = AnswerFlag.AGENT_ANSWER.code