fix:bug

src/core/callcenter/dao.py

@@ -456,4 +456,31 @@ class CallRecord(db.Model):
             'create_time': self.create_time.isoformat() if self.create_time else None,
             'update_by': self.update_by,
             'update_time': self.update_time.isoformat() if self.update_time else None,
+        }
+
+class BotRecords(db.Model):
+    __tablename__ = 'botrecords'
+    __table_args__ = {'comment': '记录机器人会话信息'}
+
+    id = db.Column(db.Integer, primary_key=True, autoincrement=True, comment='主键')
+    session = db.Column(db.String(50), nullable=False, unique=True, comment='请求ID')
+    req_time = db.Column(db.DateTime, nullable=True, comment='来电时间')
+    uid = db.Column(db.String(20), nullable=True, comment='来电手机号')
+    bid = db.Column(db.String(20), nullable=True, comment='话术ID')
+    intent = db.Column(db.String(20), nullable=True, comment='意图')
+    contents = db.Column(db.Text, nullable=True, comment='内容')
+    dialog = db.Column(db.Text, nullable=True, comment='对话')
+    def __repr__(self):
+        return json.dumps(self.to_dict())
+
+    def to_dict(self):
+        return {
+            'id': self.id,
+            'session': self.session,
+            'req_time': self.req_time.isoformat() if self.req_time else None,
+            'uid': self.uid,
+            'bid': self.bid,
+            'intent': self.intent,
+            'contents': self.contents,
+            'dialog': self.dialog,
         }

src/core/callcenter/data_handler.py

@@ -55,4 +55,10 @@ class DataHandleServer:
     def update_agent_monitor_service_state(self, agent_num,service_state):
         agent_monitor = AgentMonitor.query.filter(agent_num == agent_num).first()
         agent_monitor.service_state = service_state
+        db.session.commit()
+
+    @with_app_context
+    def update_call_record_bussiness_type(self, session):
+        BotRecord = BotRecords.query.filter(session == session).first()
+        self.update_record(session, {"bussiness_type": BotRecord.intent})
         db.session.commit()

src/core/callcenter/esl/client.py

@@ -49,6 +49,7 @@ class InboundClient:
         self.executors = {x: concurrent.futures.ThreadPoolExecutor(max_workers=1) for x in range(self.thread_num)}
         self.delay_action_executor = concurrent.futures.ThreadPoolExecutor(max_workers=5)
         self.delay_action_scheduler = BackgroundScheduler()
+        self.dataHandleServer = DataHandleServer(app)
         # self.delay_action_scheduler.add_job(self.submit_delay_action, 'interval', seconds=1, max_instances=1)
         # self.delay_action_scheduler.start()
         threading.Thread(target=self.start, args=()).start()
@@ -171,7 +172,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})
     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:

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

@@ -24,7 +24,7 @@ class ChannelBridgeHandler(EslEventHandler):
         if not call.answer_time:
             call.answer_time = EslEventUtil.getEventDateTimestamp(event)
             self.cache.add_call_info(call)
-
+        self.dataHandleServer.update_record(call_id, {"status": 1})
         self.logger.info("bridge call_info.answer_time:%s,device_info.answer_time%s,device.device_type%s" % (call.answer_time, device.answer_time,device.device_type))
         if device.device_type == DeviceType.AGENT.code: # 如果是坐席接听 变更坐席状态
             self.dataHandleServer.update_agent_monitor_service_state(call.agent_key, AgentServiceState.CALLING.code)

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

@@ -1,7 +1,7 @@
 #!/usr/bin/env python3
 # encoding:utf-8
 from src.core.callcenter.esl.annotation import EslEventName
-from src.core.callcenter.enumeration import  DeviceType, AgentServiceState,AgentScene,WorkStatus
+from src.core.callcenter.enumeration import  DeviceType,AgentScene,WorkStatus
 from src.core.callcenter.esl.constant.event_names import CHANNEL_ORIGINATE
 from src.core.callcenter.esl.handler.esl_event_handler import EslEventHandler
 import src.core.callcenter.esl.utils.esl_event_util as EslEventUtil
@@ -19,7 +19,7 @@ class ChannelOriginateHandler(EslEventHandler):
         device_id = EslEventUtil.getDeviceId(event)
         call = self.cache.get_call_info(call_id)
         device = call.device_info_map.get(device_id)
-        print('ceshisdsdsdsdsdsdsd',device.device_type,DeviceType.AGENT.code,flush=True)
         self.logger.info('ChannelOriginateHandler::event %s, device.device_type: %s, DeviceType.AGENT.code:%s ', event,device.device_type, DeviceType.AGENT.code)
+        print('ceshisdsdsdsdsdsdsd', device.device_type, DeviceType.AGENT.code, flush=True)
         if device.device_type == DeviceType.AGENT.code: # 如果是坐席接听 变更坐席状态
             self.push_handler.push_on_agent_work_report(call.saas_id, call.cti_flow_id,call.agent_key,call.call_id,AgentScene.ROBOT, WorkStatus.AGENT_RINGING)

src/core/voip/bot.py

@@ -362,6 +362,8 @@ class MyCall(pj.Call):
         elif action_code == 'transfer':  # 转人工
             print('todo 转人工')
             self.agent.transfer(user_part=self.user_part, call_id=self.session_id, device_id=self.device_id)
+            #更新通话记录机器人意图
+            self.dataHandleServer.update_call_record_bussiness_type(self.session_id)
 
 class ToTextBotAgent:
     def __init__(self, user_asr_text, call_agent):