修改

midware-api/src/main/java/midware/controller/HomeController.java

@@ -7,6 +7,7 @@ import midware.entity.database.rep.Ivr;
 import midware.entity.input.CodeInput;
 import midware.model.AjaxResult;
 import midware.service.eslclient.EslCommon;
+import midware.service.eslclient.entity.Agent;
 import midware.service.eslclient.entity.Channel;
 import midware.service.eslclient.entity.Session;
 import midware.service.init.EslClientService;
@@ -82,6 +83,35 @@ public class HomeController extends BaseController {
         return Success("",map );
     }
 
+    @GetMapping("/esl/del/{type}/{id}")
+    public AjaxResult delEsl(@PathVariable int type,@PathVariable String id) {
+        Object obj=null;
+        switch (type) {
+            case 1:
+                Agent a = EslCommon.getAgent(id);
+                if (a != null) EslCommon.agents.remove(a);
+                obj=EslCommon.agents;
+                break;
+            case 2:
+                Channel c=EslCommon.getChanByNumber(id);
+                if (c != null) EslCommon.channels.remove(c);
+                obj=EslCommon.channels;
+                break;
+            case 3:
+                Session s=EslCommon.getSessionById(id);
+                if (s != null) EslCommon.sessions.remove(s);
+                obj=EslCommon.sessions;
+                break;
+            case 4:
+                for (List<String> values : EslCommon.groupWaitList.values()) {
+                    values.remove(id);
+                }
+                obj=EslCommon.groupWaitList;
+                break;
+        }
+        return Success("",obj);
+    }
+
     @GetMapping("/midware/{type}")
     public AjaxResult Midware(@PathVariable int type) {
         List<Map<String,Object>> maps=new ArrayList<>();
@@ -155,6 +185,13 @@ public class HomeController extends BaseController {
         return result;
     }
 
+    @GetMapping("/ivr/del/{type}")
+    public boolean delIvrXml(@PathVariable Integer type) {
+        String key = "ivr:context";
+        if (type == 2) key = "ivr:menu";
+        return redisHelper.deleteCache(key);
+    }
+
     @GetMapping("/getcode")
     public void GetCode(HttpServletResponse response, CodeInput input) {
         Map<String, Object> table = SqlRunner.db().selectOne("select table_name,table_comment from information_schema.tables"

midware-service/src/main/java/midware/service/init/WebSocketService.java

@@ -172,14 +172,13 @@ public class WebSocketService {
                         String DestinationNumber = map.get("DestinationNumber").toString();
                         String Fix = map.get("Fix") != null ? map.get("Fix").toString() : "";
                         param = DestinationNumber + (Fix.equals("") ? "" : "|" + Fix);
-                        if (StringHelper.isNotEmpty(DestinationNumber)) {
-                            Agent tAgent = EslCommon.getAgentByExten(DestinationNumber);
-                            if (tAgent != null && tAgent.getAgentState() != EslAgentEnum.free.ordinal()) {
-                                result.put("Result", "目标坐席忙碌中");
-                            } else {
-                                agent.setOpType(type);
-                                isExec = eslClientService.extenCall(agent.getExten(), DestinationNumber, type + "|" + agentId + "|" + DestinationNumber + "|" + Fix);
-                            }
+
+                        String check = checkTargetNumber(agent.getExten() ,DestinationNumber);
+                        if (StringHelper.isEmpty(check)) {
+                            agent.setOpType(type);
+                            isExec = eslClientService.extenCall(agent.getExten(), DestinationNumber, type + "|" + agentId + "|" + DestinationNumber + "|" + Fix);
+                        } else {
+                            result.put("Result", check);
                         }
                     }
                     break;
@@ -213,22 +212,17 @@ public class WebSocketService {
                         String DestinationNumber = map.get("DestinationNumber").toString();
                         String Fix = map.get("Fix") != null ? map.get("Fix").toString() : "";
                         param = DestinationNumber + (Fix.equals("") ? "" : "|" + Fix);
-                        if (StringHelper.isNotEmpty(DestinationNumber)) {
-                            if (DestinationNumber.equals(agent.getExten())) {
-                                result.put("Result", "目标不能是自己");
+
+                        String check = checkTargetNumber(agent.getExten(),DestinationNumber);
+                        if (StringHelper.isEmpty(check)) {
+                            if (chan.getSessionSort() == 1) {//呼出方不可以转移
+                                result.put("Result", "主叫不能此操作");
                             } else {
-                                Agent tAgent = EslCommon.getAgentByExten(DestinationNumber);
-                                if (tAgent != null && tAgent.getAgentState() != EslAgentEnum.free.ordinal()) {
-                                    result.put("Result", "目标坐席忙碌中");
-                                } else if (EslCommon.isInSession(DestinationNumber)) {
-                                    result.put("Result", "目标号码忙碌中");
-                                } else if (chan.getSessionSort() == 1) {//呼出方不可以转移
-                                    result.put("Result", "主叫不能此操作");
-                                } else {
-                                    agent.setOpType(type);
-                                    isExec = eslClientService.transfer(chan.getSessionId(), agent.getExten(), DestinationNumber, type + "|" + agentId + "|" + DestinationNumber+ "|" + Fix);
-                                }
+                                agent.setOpType(type);
+                                isExec = eslClientService.transfer(chan.getSessionId(), agent.getExten(), DestinationNumber, type + "|" + agentId + "|" + DestinationNumber + "|" + Fix);
                             }
+                        } else {
+                            result.put("Result", check);
                         }
                     }
                     break;
@@ -238,22 +232,17 @@ public class WebSocketService {
                         String DestinationNumber = map.get("DestinationNumber").toString();
                         String Fix = map.get("Fix") != null ? map.get("Fix").toString() : "";
                         param = DestinationNumber + (Fix.equals("") ? "" : "|" + Fix);
-                        if (StringHelper.isNotEmpty(DestinationNumber)) {
-                            if (DestinationNumber.equals(agent.getExten())) {
-                                result.put("Result", "目标不能是自己");
+
+                        String check = checkTargetNumber(agent.getExten(), DestinationNumber);
+                        if (StringHelper.isEmpty(check)) {
+                            if (chan.getSessionSort() == 1) {//呼出方不可以转移
+                                result.put("Result", "主叫不能此操作");
                             } else {
-                                Agent tAgent = EslCommon.getAgentByExten(DestinationNumber);
-                                if (tAgent != null && tAgent.getAgentState() != EslAgentEnum.free.ordinal()) {
-                                    result.put("Result", "目标坐席忙碌中");
-                                } else if (EslCommon.isInSession(DestinationNumber)) {
-                                    result.put("Result", "目标号码忙碌中");
-                                } else if (chan.getSessionSort() == 1) {//呼出方不可以协商
-                                    result.put("Result", "主叫不能此操作");
-                                } else {
-                                    agent.setOpType(type);
-                                    isExec = eslClientService.consult(chan.getSessionId(), agent.getExten(), DestinationNumber, type + "|" + agentId + "|" + DestinationNumber+ "|" + Fix);
-                                }
+                                agent.setOpType(type);
+                                isExec = eslClientService.consult(chan.getSessionId(), agent.getExten(), DestinationNumber, type + "|" + agentId + "|" + DestinationNumber + "|" + Fix);
                             }
+                        } else {
+                            result.put("Result", check);
                         }
                     }
                     break;
@@ -272,22 +261,15 @@ public class WebSocketService {
                         String DestinationNumber = map.get("DestinationNumber").toString();
                         String Fix = map.get("Fix") != null ? map.get("Fix").toString() : "";
                         param = DestinationNumber + (Fix.equals("") ? "" : "|" + Fix);
-                        if (StringHelper.isNotEmpty(DestinationNumber)) {
-                            if (DestinationNumber.equals(agent.getExten())) {
-                                result.put("Result", "目标不能是自己");
-                            } else {
-                                Agent tAgent = EslCommon.getAgentByExten(DestinationNumber);
-                                if (tAgent != null && tAgent.getAgentState() != EslAgentEnum.free.ordinal()) {
-                                    result.put("Result", "目标坐席忙碌中");
-                                } else if (EslCommon.isInSession(DestinationNumber)) {
-                                    result.put("Result", "目标号码忙碌中");
-                                } else {
-                                    agent.setOpType(type);
-                                    String mute = map.get("Mute") != null ? map.get("Mute").toString() : "";
-                                    EslCommon.getSessionById(chan.getSessionId()).setMeetingMute(mute.equals("true"));
-                                    isExec = eslClientService.callJoinMeeting(agent.getExten(), DestinationNumber, chan.getSessionId(), type + "|" + agentId + "|" + DestinationNumber+ "|" + Fix);
-                                }
-                            }
+
+                        String check = checkTargetNumber(agent.getExten(), DestinationNumber);
+                        if (StringHelper.isEmpty(check)) {
+                            agent.setOpType(type);
+                            String mute = map.get("Mute") != null ? map.get("Mute").toString() : "";
+                            EslCommon.getSessionById(chan.getSessionId()).setMeetingMute(mute.equals("true"));
+                            isExec = eslClientService.callJoinMeeting(agent.getExten(), DestinationNumber, chan.getSessionId(), type + "|" + agentId + "|" + DestinationNumber+ "|" + Fix);
+                        } else {
+                            result.put("Result", check);
                         }
                     }
                     break;
@@ -348,20 +330,16 @@ public class WebSocketService {
                         String TargetAgentID = map.get("TargetAgentID").toString();
                         param = TargetAgentID;
                         if (StringHelper.isNotEmpty(TargetAgentID)) {
-                            if (TargetAgentID.equals(agentId)) {
-                                result.put("Result", "目标不能是自己");
-                            } else {
-                                Agent tAgent = EslCommon.getAgent(TargetAgentID);
-                                String check = checkTargetAgentTalk(tAgent);
-                                if (StringHelper.isEmpty(check)) {
-                                    Channel tchan = EslCommon.getChanByExten(tAgent.getExten());
-                                    if (tchan != null && StringHelper.isNotEmpty(tchan.getSessionId())) {
-                                        agent.setOpType(type);
-                                        isExec = eslClientService.listen(agent.getExten(),tchan.getNumber(), tchan.getSessionId(), type + "|" + agentId + "|" + agent.getExten());
-                                    }
-                                } else {
-                                    result.put("Result", check);
+                            Agent tAgent = EslCommon.getAgent(TargetAgentID);
+                            String check = checkTargetAgentTalk(tAgent);
+                            if (StringHelper.isEmpty(check)) {
+                                Channel tchan = EslCommon.getChanByExten(tAgent.getExten());
+                                if (tchan != null && StringHelper.isNotEmpty(tchan.getSessionId())) {
+                                    agent.setOpType(type);
+                                    isExec = eslClientService.listen(agent.getExten(),tchan.getNumber(), tchan.getSessionId(), type + "|" + agentId + "|" + agent.getExten());
                                 }
+                            } else {
+                                result.put("Result", check);
                             }
                         }
                     }
@@ -372,21 +350,17 @@ public class WebSocketService {
                         String TargetAgentID = map.get("TargetAgentID").toString();
                         param = TargetAgentID;
                         if (StringHelper.isNotEmpty(TargetAgentID)) {
-                            if (TargetAgentID.equals(agentId)) {
-                                result.put("Result", "目标不能是自己");
-                            } else {
-                                Agent tAgent = EslCommon.getAgent(TargetAgentID);
-                                String check = checkTargetAgentTalk(tAgent);
-                                if (StringHelper.isEmpty(check)) {
-                                    Channel tchan = EslCommon.getChanByExten(tAgent.getExten());
-                                    if (tchan != null && StringHelper.isNotEmpty(tchan.getSessionId())) {
-                                        agent.setOpType(type);
-                                        String sid = tchan.getSessionId();
-                                        isExec = eslClientService.insert(agent.getExten(), tchan.getNumber(), sid, type + "|" + agentId + "|" + agent.getExten());
-                                    }
-                                } else {
-                                    result.put("Result", check);
+                            Agent tAgent = EslCommon.getAgent(TargetAgentID);
+                            String check = checkTargetAgentTalk(tAgent);
+                            if (StringHelper.isEmpty(check)) {
+                                Channel tchan = EslCommon.getChanByExten(tAgent.getExten());
+                                if (tchan != null && StringHelper.isNotEmpty(tchan.getSessionId())) {
+                                    agent.setOpType(type);
+                                    String sid = tchan.getSessionId();
+                                    isExec = eslClientService.insert(agent.getExten(), tchan.getNumber(), sid, type + "|" + agentId + "|" + agent.getExten());
                                 }
+                            } else {
+                                result.put("Result", check);
                             }
                         }
                     }
@@ -397,22 +371,18 @@ public class WebSocketService {
                         String TargetAgentID = map.get("TargetAgentID").toString();
                         param = TargetAgentID;
                         if (StringHelper.isNotEmpty(TargetAgentID)) {
-                            if (TargetAgentID.equals(agentId)) {
-                                result.put("Result", "目标不能是自己");
-                            } else {
-                                Agent tAgent = EslCommon.getAgent(TargetAgentID);
-                                String check = checkTargetAgentTalk(tAgent);
-                                if (StringHelper.isEmpty(check)) {
-                                    Channel tchan = EslCommon.getChanByExten(tAgent.getExten());
-                                    if (tchan != null && StringHelper.isNotEmpty(tchan.getSessionId())) {
-                                        agent.setOpType(type);
-                                        String sid = tchan.getSessionId();
-                                        Channel channel = EslCommon.getFirstChanBySessionId(sid);
-                                        isExec = eslClientService.intercept(agent.getExten(), tAgent.getExten(), channel.getChanId(), sid, type + "|" + agentId + "|" + agent.getExten());
-                                    }
-                                } else {
-                                    result.put("Result", check);
+                            Agent tAgent = EslCommon.getAgent(TargetAgentID);
+                            String check = checkTargetAgentTalk(tAgent);
+                            if (StringHelper.isEmpty(check)) {
+                                Channel tchan = EslCommon.getChanByExten(tAgent.getExten());
+                                if (tchan != null && StringHelper.isNotEmpty(tchan.getSessionId())) {
+                                    agent.setOpType(type);
+                                    String sid = tchan.getSessionId();
+                                    Channel channel = EslCommon.getFirstChanBySessionId(sid);
+                                    isExec = eslClientService.intercept(agent.getExten(), tAgent.getExten(), channel.getChanId(), sid, type + "|" + agentId + "|" + agent.getExten());
                                 }
+                            } else {
+                                result.put("Result", check);
                             }
                         }
                     }
@@ -422,19 +392,15 @@ public class WebSocketService {
                         String TargetAgentID = map.get("TargetAgentID").toString();
                         param = TargetAgentID;
                         if (StringHelper.isNotEmpty(TargetAgentID)) {
-                            if (TargetAgentID.equals(agentId)) {
-                                result.put("Result", "目标不能是自己");
-                            } else {
-                                Agent tAgent = EslCommon.getAgent(TargetAgentID);
-                                String check = checkTargetAgentTalk(tAgent);
-                                if (StringHelper.isEmpty(check)) {
-                                    Channel tchan = EslCommon.getChanByExten(tAgent.getExten());
-                                    if (tchan != null && StringHelper.isNotEmpty(tchan.getSessionId())) {
-                                        isExec = eslClientService.kill(tchan.getSessionId(),type + "|" + agentId);
-                                    }
-                                } else {
-                                    result.put("Result", check);
+                            Agent tAgent = EslCommon.getAgent(TargetAgentID);
+                            String check = checkTargetAgentTalk(tAgent);
+                            if (StringHelper.isEmpty(check)) {
+                                Channel tchan = EslCommon.getChanByExten(tAgent.getExten());
+                                if (tchan != null && StringHelper.isNotEmpty(tchan.getSessionId())) {
+                                    isExec = eslClientService.kill(tchan.getSessionId(),type + "|" + agentId);
                                 }
+                            } else {
+                                result.put("Result", check);
                             }
                         }
                     }
@@ -542,8 +508,37 @@ public class WebSocketService {
         String result = "";
         if (agent == null) {
             result = "目标坐席未签入";
-        } else if (agent.getAgentState() != EslAgentEnum.talking.ordinal()) {
-            result = "目标坐席未通话";
+        } else {
+            if (agent.getAgent().equals(agentId)) {
+                result = "目标不能是自己";
+            }else if (agent.getAgentState() != EslAgentEnum.talking.ordinal()) {
+                result = "目标坐席未通话";
+            }
+        }
+        return result;
+    }
+
+    //判断目标号码是否可以呼出
+    private String checkTargetNumber(String exten,String num) {
+        String result = "";
+        if (StringHelper.isEmpty(num)) {
+            result = "目标号码不能为空";
+        } else {
+            if (exten.equals(num)) {
+                result = "目标不能是自己";
+            } else {
+                Channel chan = EslCommon.getChanByNumber(num);
+                if (chan != null) {
+                    if (!chan.getSessionId().equals("")) {
+                        result = "目标号码忙碌中";
+                    } else if (chan.getType() == 1) {//坐席
+                        Agent tAgent = EslCommon.getAgentByExten(num);
+                        if (tAgent != null && tAgent.getAgentState() != EslAgentEnum.free.ordinal()) {
+                            result = "目标坐席忙碌中";
+                        }
+                    }
+                }
+            }
         }
         return result;
     }