|
|
@@ -538,12 +538,14 @@ class OutboundClient:
|
|
|
bucket = self.server.get_bucket(call_id)
|
|
|
whitelist = self.server.get_whitelist()
|
|
|
in_whitelist_type = self.in_whitelist(caller_number, whitelist)
|
|
|
+ user_name = None
|
|
|
self.server.logger.info('call incoming call_id=%s, caller_number=%s, device_id=%s, new_device_id=%s, in_whitelist=%s, bucket=%s', call_id, caller_number, device_id, new_device_id, in_whitelist_type, bucket.name)
|
|
|
# 检查白名单
|
|
|
if in_whitelist_type:
|
|
|
if WhiteTypeEnum.AI == in_whitelist_type:
|
|
|
bucket_call_type = 0
|
|
|
service_category = 1
|
|
|
+ user_name = f"机器人{destination}"
|
|
|
destination = self.bridge_ai(con, bucket_call_type, call_id, device_id, new_device_id, **kwargs)
|
|
|
else:
|
|
|
bucket_call_type = 0
|
|
|
@@ -553,12 +555,13 @@ class OutboundClient:
|
|
|
if bucket and bucket.name == 'AI':
|
|
|
bucket_call_type = 1
|
|
|
service_category = 1
|
|
|
+ user_name = f"机器人{destination}"
|
|
|
destination = self.bridge_ai(con, bucket_call_type, call_id, device_id, new_device_id, **kwargs)
|
|
|
else:
|
|
|
self.transfer_custom(con, bucket_call_type, call_id, device_id, new_device_id, **kwargs)
|
|
|
|
|
|
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, user_id=destination if bucket_call_type == 1 else None , user_name= f"机器人{destination}" if bucket_call_type ==1 else None)
|
|
|
+ self.server.dataHandleServer.create_record(call_id, caller_number, bucket_call_type, service_category=service_category, user_id=destination if user_name else None, user_name= user_name)
|
|
|
|
|
|
try:
|
|
|
con.disconnect()
|
