|
|
@@ -6,7 +6,7 @@ from datetime import datetime
|
|
|
from queue import Queue
|
|
|
from typing import Dict, Any, Optional
|
|
|
from src.core.callcenter.cache import Cache
|
|
|
-from src.core.callcenter.agent import AgentOperService
|
|
|
+from src.core.callcenter.agent import AgentOperService, AgentStateService
|
|
|
from src.core.callcenter.call import CallService
|
|
|
from src.core.callcenter.api import CallInfo, AgentActionRequest, DelayAction
|
|
|
from apscheduler.schedulers.background import BackgroundScheduler
|
|
|
@@ -24,6 +24,7 @@ class AcdService:
|
|
|
self.cache = Cache(app)
|
|
|
self.call_service = CallService(client, app)
|
|
|
self.agent_service = AgentOperService(app)
|
|
|
+ self.agent_state_service = AgentStateService(app)
|
|
|
self.holdsQueue: Dict[str, Queue] = {}
|
|
|
self.pool = ThreadPoolExecutor(max_workers=4)
|
|
|
self.checkIdleScheduler = BackgroundScheduler()
|
|
|
@@ -54,6 +55,7 @@ class AcdService:
|
|
|
# print(text, flush=True)
|
|
|
self.logger.info(text)
|
|
|
self.call_service.transfer(call_info, agent_number, service_id)
|
|
|
+ self.agent_state_service.busy(call_info.saas_id, agent_number, agent_number)
|
|
|
self.cache.add_call_info(call_info)
|
|
|
|
|
|
def try_transfer_agent(self):
|
