服务站大屏

pom.xml

@@ -198,6 +198,11 @@
             <groupId>org.springframework</groupId>
             <artifactId>spring-test</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.java-websocket</groupId>
+            <artifactId>Java-WebSocket</artifactId>
+            <version>1.3.5</version>
+        </dependency>
         <!-- 引入redis及相关组件 -->
         <!--<dependency>
             <groupId>org.springframework.boot</groupId>

src/main/java/com/care/bigscreen/service/BigScreenService.java

@@ -73,4 +73,8 @@ public interface BigScreenService {
      */
     PageUtil<BigScreenOlderDetailVO> selectBigScreenOlderCardListByPage(Long stationId, String olderName, PageResVO page);
 
+    /**
+     * 调用websocket推送实时事件标识给前端
+     */
+    void pushRtEventFlag(String stationId);
 }

src/main/java/com/care/bigscreen/service/impl/BigScreenServiceImpl.java

@@ -4,6 +4,7 @@ package com.care.bigscreen.service.impl;
 import com.care.bigscreen.mapper.BigSreenMapper;
 import com.care.bigscreen.service.BigScreenService;
 import com.care.bigscreen.vo.*;
+import com.care.bigscreen.websocket.BigScreenWebSocketEndpoint;
 import com.care.common.vo.PageResVO;
 import com.care.util.PageUtil;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -137,4 +138,12 @@ public class BigScreenServiceImpl implements BigScreenService {
         pageUtil.setListT(bigScreenOlderDetailVOList);
         return pageUtil;
     }
+
+    /**
+     * 调用websocket推送实时事件标识给前端
+     */
+    @Override
+    public void pushRtEventFlag(String stationId) {
+        BigScreenWebSocketEndpoint.sendMsgToFront(stationId,"happen");
+    }
 }

src/main/java/com/care/bigscreen/websocket/BigScreenWebSocketEndpoint.java

@@ -0,0 +1,188 @@
+package com.care.bigscreen.websocket;
+
+
+import com.care.util.ExUtil;
+import com.care.util.JsonUtil;
+import com.care.util.Result;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+import org.springframework.util.StringUtils;
+
+import javax.websocket.*;
+import javax.websocket.server.ServerEndpoint;
+import java.io.IOException;
+import java.util.concurrent.CopyOnWriteArraySet;
+
+/**
+ * Swagger2配置
+ *
+ * @author stw
+ * @version 1.0.0 创建于 2021/5/24
+ **/
+@ServerEndpoint("/bms/bigscreen/ws")
+@Component
+public class BigScreenWebSocketEndpoint {
+    private static final Logger logger = LoggerFactory.getLogger(BigScreenWebSocketEndpoint.class);
+    //用来存放每个客户端对应的BigScreenWebSocketEndpoint对象
+    private static CopyOnWriteArraySet<BigScreenWebSocketEndpoint> currentWebSocketSession = new CopyOnWriteArraySet<>();
+
+    // 与某个客户端的连接会话，需要通过它来与客户端进行数据收发
+    private Session session;
+    //用于关联当前客户端和websocket会话的关系
+
+    //登录名
+    private String username;
+
+    //服务站ID
+    private String stationId;
+
+
+    /**
+     * websocket 连接打开操作
+     *
+     * @param session websocket会话对象
+     */
+    @OnOpen
+    public void webSocketOnOpen(Session session) {
+        try {
+            //校验参数
+            String requestParamString = session.getQueryString();
+            if (StringUtils.isEmpty(requestParamString)) {
+                closeSession(session, "-1", "连接失败,token为空");
+                return;
+            }
+            //建立websocket和自动外呼坐席的关联关系
+            //从token中解析出坐席的信息
+            String[] keyValues = requestParamString.split("&");
+            //取出token 字符串
+            String ts = null;
+
+            for (String t : keyValues) {
+                if (t.startsWith("token=")) {
+                    ts = t.replaceAll("token=", "");
+                } else if (t.startsWith("stationId=")) {
+                    stationId = t.replaceAll("stationId=", "");
+                }
+            }
+//            if (StringUtils.isEmpty(ts) || StringUtils.isEmpty(stationId)) {
+//                closeSession(session, "-1", "连接失败,token或stationId为空");
+//                return;
+//            }
+//
+//            //连接对象初始化
+//            Token token = null;
+//            try {
+//                token = TokenUtil.parseTokenStr(ts);
+//            } catch (Exception e) {
+//                logger.error("websocket会话建立异常:"+ ExUtil.exToDetail(e));
+//            }
+//            if(token == null){
+//                closeSession(session, "-1", "连接失败,token为空");
+//                return;
+//            }
+//
+//            logger.info("websocket会话建立:登录用户={},服务站ID={}登录！", token.getPayload().getUsername(), this.stationId);
+//            this.username = token.getPayload().getUsername();
+            this.session = session;
+            currentWebSocketSession.add(this);
+        } catch (Exception e) {
+            closeSession(session, "-1", "连接失败,token为空");
+            logger.error("websocket会话建立异常:"+ ExUtil.exToDetail(e));
+        }
+    }
+
+    @OnClose
+    public void onClose(Session session) {
+        //移除连接
+        currentWebSocketSession.remove(this);
+        logger.info("客户端断开连接,客户端id={},坐席={},退出自动外呼", session.getId(), this.username);
+    }
+
+    @OnError
+    public void onError(Session session, Throwable error) {
+        logger.error("客户端id={},服务站ID={},登录用户={},连接异常信息={}.", session.getId(), this.stationId, this.username, error.getCause());
+    }
+
+    @OnMessage
+    public void onMessage(String message, Session session) throws Exception {
+//        logger.info("Receive a message from client: " + message);
+        // 页面传过来的消息不做任何处理
+        logger.info("收到来自" + session.getId() + "的消息" + message);
+        //返回消息给Web Socket客户端（浏览器）
+//        sendMessage(message);
+    }
+
+    public static void sendMessage(String message) throws IOException {
+        for (BigScreenWebSocketEndpoint endpoint : currentWebSocketSession) {
+            Session session = endpoint.getSession();
+            if (session.isOpen()) {
+                //发送消息
+                try {
+                    session.getBasicRemote().sendText(message);
+                } catch (IOException e) {
+                    logger.info("给服务站ID={},登录用户={} 发送数据失败，客户端连接已经断开.", endpoint.getStationId(), endpoint.getUsername());
+                }
+            }
+        }
+    }
+
+    /**
+     * 给客户端发送消息的方法
+     *
+     * @param stationId 服务站ID
+     * @param msg        发送的信息
+     */
+    public static void sendMsgToFront(String stationId,String msg) {
+        //根据服务站ID，匹配连接并发送消息
+        for (BigScreenWebSocketEndpoint endpoint : currentWebSocketSession) {
+            Session session = endpoint.getSession();
+            if (session.isOpen() && stationId.equals(endpoint.getStationId())) {
+                //发送消息
+                try {
+                    session.getBasicRemote().sendText(msg);
+                } catch (IOException e) {
+                    logger.info("给服务站ID={}，登录用户={} 发送数据失败，客户端连接已经断开.", endpoint.getStationId(), endpoint.getUsername());
+                }
+            }
+        }
+
+    }
+
+
+    /**
+     * 关闭session操作
+     *
+     * @param session
+     * @param msg
+     * @throws Exception
+     */
+    private void closeSession(Session session,  String code, String msg) {
+        try {
+            if (session != null){
+                if("-1".equals(code)){
+                    session.getBasicRemote().sendText(JsonUtil.toJson(Result.error(msg)));
+                } else {
+                    session.getBasicRemote().sendText(JsonUtil.toJson(Result.success(msg)));
+                }
+
+                session.close();
+            }
+
+        } catch (Exception e) {
+            logger.info("关闭连接异常", e.getCause());
+        }
+    }
+
+    public Session getSession() {
+        return session;
+    }
+
+    public String getUsername() {
+        return username;
+    }
+
+    public String getStationId() {
+        return stationId;
+    }
+}

src/main/java/com/care/util/ExUtil.java

@@ -0,0 +1,23 @@
+package com.care.util;
+
+import java.io.PrintWriter;
+import java.io.StringWriter;
+
+/**
+ * @author 宋显哲
+ * @version 1.0.0 创建于 2019/1/28
+ **/
+public class ExUtil {
+
+    /**
+     * 打印详细的堆栈错误信息
+     *
+     * @param throwable
+     * @return
+     */
+    public static String exToDetail(Throwable throwable) {
+        StringWriter stringWriter = new StringWriter();
+        throwable.printStackTrace(new PrintWriter(stringWriter));
+        return stringWriter.getBuffer().toString();
+    }
+}