debug

src/core/callcenter/cache.py

@@ -153,4 +153,12 @@ class Cache:
 
     def del_need_play_hold_music(self, call_id):
         key = NEED_PLAY_HOLD_MUSIC % call_id
-        self.delete_key(key)
+        self.delete_key(key)
+
+    def set_after_play_hold_music(self, call_id):
+        key = AFTER_PLAY_HOLD_MUSIC % call_id
+        return self.redis_handler.redis.set(key, "1", ex=60 * 1, nx=True)
+
+    def get_after_play_hold_music(self, call_id):
+        key = AFTER_PLAY_HOLD_MUSIC % call_id
+        return self.redis_handler.redis.get(key)

src/core/callcenter/constant.py

@@ -81,6 +81,7 @@ DELAY_ACTION_BATCH_SIZE = 10
 CTI_ENGINE_DELAY_ACTION = "DELAY:ACTION:%s"
 CTI_ENGINE_DELAY_ACTION_LOCK = "DELAY:ACTION:LOCK:%s"
 NEED_PLAY_HOLD_MUSIC = "CTI:ENGINE:NEED:HOLD:%s"
+AFTER_PLAY_HOLD_MUSIC = "CTI:ENGINE:AFTER:HOLD:%s"
 
 def get_json_dict(json_text=None):
     if isinstance(json_text, str):

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

@@ -48,7 +48,8 @@ class ChannelParkHandler(EslEventHandler):
         self.logger.info('debugger, ChannelParkHandler, hold=%s, device_info=%s' % (hold, device_info))
         if hold and device_info.device_type == DeviceType.CUSTOMER.code:
             self.inbound_client.hold_play(device_id, HOLD_MUSIC_PATH)
-            # self.cache.del_need_play_hold_music(call_id)
+            self.cache.del_need_play_hold_music(call_id)
+            self.cache.set_after_play_hold_music(call_id)
             # self.inbound_client.set_var(device_id, SIP_HEADER + sipHeaderHoldMusic, "false")
 
     def process_fxo_calling(self, event):

src/core/voip/bot.py

@@ -552,13 +552,12 @@ class BotAgent:
         if self.acd_service:
             self.acd_service.transfer_to_agent(call_id, device_id, service_id, user_part)
         # sip_headers = {'P-LIBRA-HangUpReason': 'transferToAgent', 'P-LIBRA-ServiceId': service_id}
-        try_count = 10
+        try_count = 100
         while try_count >0:
-            if self.cache.get_need_play_hold_music(call_id):
+            if self.cache.get_after_play_hold_music(call_id):
                 self.hangup(user_part)
-                # self.cache.del_need_play_hold_music(call_id)
                 break
-            time.sleep(1)
+            time.sleep(0.1)
 
 
     def hangup(self, user_part, reason="NORMAL_CLEARING", **sip_headers):