fix: bug

src/core/callcenter/call.py

@@ -60,15 +60,15 @@ class CallService:
                                   sip_header_map={sipHeaderCtiFlowId: request.cti_flow_id})
 
         self.client.make_call(context)
-        self.do_after_manual_call(call_info, agent.agent_number)
+        self.do_after_manual_call(call_info, agent.agent_number,agent)
         return call_id
 
-    def do_after_manual_call(self, call_info: CallInfo, agent_id):
+    def do_after_manual_call(self, call_info: CallInfo, agent_id,agent):
         agent_monitor = self.data_handle_server.get_agent_monitor(call_info.saas_id, agent_number=agent_id)
         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, category=1)
+        self.data_handle_server.create_record(call_info.call_id, call_info.called, call_info.call_type, service_category=0, category=1 , user_id=agent.user_id, user_name=agent.agent_name)
 
     def hold(self, call_id, device_id):
         self.logger.info('hold, custom_device_id=%s'%device_id)

src/core/callcenter/data_handler.py

@@ -9,7 +9,7 @@ class DataHandleServer:
         self.app = app
 
     @with_app_context
-    def create_record(self, call_id, caller_number, call_type, service_category=None, destination=None, category=0):
+    def create_record(self, call_id, caller_number, call_type, service_category=None, category=0, user_id=None,user_name=None):
         call_info = {
             "session_id": call_id,
             "time_begin": datetime.now(),
@@ -17,8 +17,8 @@ class DataHandleServer:
             "phone": caller_number,
             "type": call_type,
             "service_category": service_category,
-            "user_id":destination,
-            "user_name": f"机器人{destination}" if destination else None,
+            "user_id":user_id,
+            "user_name": user_name,
         }
         call_record = CallRecord()
         self.app.logger.info(f"创建通话记录: {call_info}")

src/core/callcenter/esl/client.py

@@ -561,7 +561,7 @@ class OutboundClient:
                         self.server.agent.acd_service.transfer_to_agent(call_id, device_id)
 
                     registry.CALL_INCOMING_REQUESTS.labels(f"{_bucket_call_type}").inc()
-                    self.server.dataHandleServer.create_record(call_id, caller_number, _bucket_call_type, service_category=service_category, destination=destination)
+                    self.server.dataHandleServer.create_record(call_id, caller_number, _bucket_call_type, service_category=service_category, user_id=destination if _bucket_call_type == 1 else None , user_name=  f"机器人{destination}" if _bucket_call_type ==1 else None)
 
                     try:
                         con.disconnect()

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

@@ -168,6 +168,12 @@ class ChannelHangupHandler(EslEventHandler):
                 self.dataHandleServer.update_record(call_id, time_end=datetime.now(), sip_status=sip_status, sip_hangup_cause=hangup_cause, status=status)
                 return
             merge_record = self.merge_audio_files(records) if len(records) > 1 else records[0]
+            try:
+                os.chmod(merge_record, 0o755)
+                self.logger.info("成功设置文件权限: %s -> 755", merge_record)
+            except Exception as chmod_error:
+                self.logger.error("设置文件权限失败: %s, error: %s", merge_record, str(chmod_error))
+
             self.dataHandleServer.update_record(call_id, time_end=datetime.now(), url=merge_record, sip_status=sip_status, sip_hangup_cause=hangup_cause, status=status)
             self.logger.info("更新录音记录完成: call_id=%s", call_id)
         except Exception as e:

src/core/voip/asr.py

@@ -125,13 +125,13 @@ class TestSt:
             on_close=self.test_on_close,
             callback_args=[self.__id]
         )
-        self.sr.__setattr__("max_sentence_silence", 1200)
         self.sr.start(
             aformat="pcm",
             enable_intermediate_result=True,
             enable_punctuation_prediction=True,
             enable_inverse_text_normalization=True
         )
+        self.sr.ctrl(ex={'max_sentence_silence': '1200ms', 'disfluency': True,'enable_words': True })
         print("ASR session started.")
 
     def test_on_sentence_begin(self, message, *args):