连续报警功能模块开发,fix

src/core/callcenter/agent.py

@@ -17,7 +17,7 @@ from src.core import with_app_context
 from src.core.callcenter.api import AgentActionRequest, AgentQueryRequest, AgentRequest, AgentEventData, \
     AgentStateData, HumanServiceQueryRequest, AgentMonitorData, CallInfo, DeviceInfo, AgentDelayStateData
 from src.core.callcenter.cache import Cache
-from src.core.callcenter.constant import CENTER_AGENT_HEARTBEAT, SAAS_ID
+from src.core.callcenter.constant import CENTER_AGENT_HEARTBEAT, SAAS_ID, CENTER_AGENT_LIVE_CNT
 from src.core.callcenter.dao import *
 from src.core.callcenter.data_handler import DataHandleServer
 from src.core.callcenter.enumeration import AgentState, AgentCheck, AgentHeartState, AgentServiceState, AgentLogState, \
@@ -287,7 +287,7 @@ class AgentOperService:
                 traceback.print_exc()
 
         def check_agent_live_daemon(_members):
-            key = '' % SAAS_ID
+            key = CENTER_AGENT_LIVE_CNT % SAAS_ID
             pre_val = self.redis_handler.redis.get(key)
             if not pre_val:
                 if not _members or len(_members) == 0:

src/core/callcenter/constant.py

@@ -94,6 +94,7 @@ BOT_REGISTER_PER_HOURS = "BOT:REGISTER:PER_HOURS:%s"
 BOT_PJSUA_THREAD_LOCK = "BOT:PJSUA:THREAD:LOCK:%s"
 CALL_SERIAL_NO_ANSWER = "CALL:SERIAL:NO_ANSWER:%s"
 CALL_SERIAL_SPEED_HANGUP = "CALL:SERIAL:SPEED:HANGUP:%s"
+CENTER_AGENT_LIVE_CNT = "CENTER:AGENT:LIVE:CNT:%s"
 
 def get_json_dict(json_text=None):
     if isinstance(json_text, str):