|
|
@@ -134,7 +134,7 @@ class ChannelHangupHandler(EslEventHandler):
|
|
|
# 全部挂机以后推送挂机状态
|
|
|
# self.logger.info('yushanghui::call_info.device_list %s', call_info.device_list)
|
|
|
if len(call_info.device_list) == 0:
|
|
|
- self.get_call_info_record(call_info, device_info)
|
|
|
+ self.get_call_info_record(call_info)
|
|
|
|
|
|
# 判断挂机方向 && 更新缓存
|
|
|
self.hangup_dir(call_info, device_info, cause)
|
|
|
@@ -143,13 +143,17 @@ class ChannelHangupHandler(EslEventHandler):
|
|
|
except:
|
|
|
traceback.print_exc()
|
|
|
|
|
|
- def get_call_info_record(self, call_info, device_info):
|
|
|
+ def get_call_info_record(self, call_info):
|
|
|
records = []
|
|
|
+ sip_status = []
|
|
|
+ hangup_cause = []
|
|
|
for value in call_info.device_info_map.values():
|
|
|
records.append(value.record) if value.record else None
|
|
|
+ sip_status.append(value.sip_status)
|
|
|
+ hangup_cause.append(value.hangup_cause)
|
|
|
self.logger.info("get_call_info_record: %s", records)
|
|
|
if records:
|
|
|
- threading.Thread(target=self._update_record_in_thread, args=(call_info.call_id, records, device_info.sip_status, device_info.hangup_cause)).start()
|
|
|
+ threading.Thread(target=self._update_record_in_thread, args=(call_info.call_id, records, ",".join(sip_status), ",".join(hangup_cause))).start()
|
|
|
else:
|
|
|
self.logger.warning("没有找到有效的录音文件")
|
|
|
|
DavidLiu