余尚辉 4 months ago
parent
commit
4b7d45de4b
2 changed files with 19 additions and 33 deletions
  1. 2 0
      src/core/callcenter/agent.py
  2. 17 33
      src/core/callcenter/views.py

+ 2 - 0
src/core/callcenter/agent.py

@@ -558,6 +558,7 @@ class AgentStateService:
 
     def handle_assign_time(self, saas_id, service_id, choose_phone_num):
         key = self._key(saas_id, service_id)
+        print(1111111)
         cache_agent_map = self.get_cache_agent_map(saas_id, service_id)
         if cache_agent_map and choose_phone_num in cache_agent_map:
             state_data = cache_agent_map[choose_phone_num]
@@ -591,6 +592,7 @@ class AgentStateService:
         # self.update_report_state(saas_id, service_id)
 
     def busy_hash(self, saas_id, agent_id, phone_num, service_id):
+        print("busy_hash23232323")
         cache_agent_map = self.get_cache_agent_map(saas_id, service_id)
         state_data = cache_agent_map.get(phone_num)
         key = self._key(saas_id, service_id)

+ 17 - 33
src/core/callcenter/views.py

@@ -67,59 +67,43 @@ def get_init_config():
 
     except Exception as e:
         print("Exception occurred: %s", str(e))
-        return error_response(e)
+        return error_response(str(e))
 
 
 @app.route('/open/agent/check-in', methods=['POST'])
 def check_in():
     """坐席签入"""
-    try:
-        data = request.get_json()
-        param = AgentActionRequest.from_json(data)
-        res = agent_oper_service.checkin(param)
-        return success_response(res)
-    except Exception as e:
-        print("Exception occurred: %s", str(e))
-        return error_response(e)
+    data = request.get_json()
+    param = AgentActionRequest.from_json(data)
+    res = agent_oper_service.checkin(param)
+    return success_response(res)
 
 
 @app.route('/open/agent/check-out', methods=['POST'])
 def check_out():
     """坐席签出"""
-    try:
-        data = request.get_json()
-        param = AgentActionRequest.from_json(data)
-        res= agent_oper_service.checkout(param)
-        return success_response(res)
-    except Exception as e:
-        print("Exception occurred: %s", str(e))
-        return error_response(e)
+    data = request.get_json()
+    param = AgentActionRequest.from_json(data)
+    res = agent_oper_service.checkout(param)
+    return success_response(res)
 
 
 @app.route('/open/agent/busy', methods=['POST'])
 def busy():
     """坐席置忙"""
-    try:
-        data = request.get_json()
-        param = AgentActionRequest.from_json(data)
-        res= agent_oper_service.busy(param)
-        return success_response(res)
-    except Exception as e:
-        print("Exception occurred: %s", str(e))
-        return error_response(e)
+    data = request.get_json()
+    param = AgentActionRequest.from_json(data)
+    res = agent_oper_service.busy(param)
+    return success_response(res)
 
 
 @app.route('/open/agent/idle', methods=['POST'])
 def idle():
     """坐席置闲"""
-    try:
-        data = request.get_json()
-        param = AgentActionRequest.from_json(data)
-        res = agent_oper_service.idle(param)
-        return success_response(res)
-    except Exception as e:
-        print("Exception occurred: %s", str(e))
-        return {"error": "An error occurred", "details": str(e)}, 500
+    data = request.get_json()
+    param = AgentActionRequest.from_json(data)
+    res = agent_oper_service.idle(param)
+    return success_response(res)
 
 
 @app.route('/open/agent/turn-on', methods=['POST'])