修改微信客服聊天

webapidemo-api/src/main/java/com/example/controller/system/UserController.java

@@ -354,9 +354,13 @@ public class UserController extends BaseController {
         Long userId = CurrentUser().getUserId();
         qw.eq(User::getUserId, userId);
         User user = userService.getEntity(qw);
+        System.out.println(JSON.toJSONString(user));
         if ("0".equals(user.getIsKefu())) {
-            user.setOnlineType("0");
-            userService.update(user);
+//            user.setOnlineType("0");
+//            userService.update(user);
+            User up=new User();
+            up.setOnlineType("0");
+            userService.updateBatch(up,qw);
             updateGroupQueue();
             userService.getKefuMessage(CurrentUser().getUserId().toString());
             return Success("签入成功!");
@@ -374,8 +378,11 @@ public class UserController extends BaseController {
         qw.eq(User::getUserId, userId);
         User user = userService.getEntity(qw);
         if ("0".equals(user.getIsKefu())) {
-            user.setOnlineType("2");
-            userService.update(user);
+//            user.setOnlineType("2");
+//            userService.update(user);
+            User up=new User();
+            up.setOnlineType("2");
+            userService.updateBatch(up,qw);
             updateGroupQueue();
             String queueName = "kefu_" + userId;
             Set<String> keys = redisHelper.getSetKeys(queueName + "*");
@@ -395,9 +402,12 @@ public class UserController extends BaseController {
         queryWrapper.eq(User::getUserId, userId);
         User user = userService.getEntity(queryWrapper);
         if ("0".equals(user.getIsKefu())) {
-            user.setOnlineType("1");
+            //user.setOnlineType("1");
+            //boolean update = userService.update(user);
+            User up=new User();
+            up.setOnlineType("1");
+            boolean update =userService.updateBatch(up,queryWrapper);
             String queueName = "kefu_" + userId;
-            boolean update = userService.update(user);
             if (update) {
                 updateGroupQueue();
                 //生成模糊匹配的对应的set集合，字符串后面追加的*号做模糊匹配使用
@@ -420,8 +430,11 @@ public class UserController extends BaseController {
         queryWrapper.eq(User::getUserId, userId);
         User user = userService.getEntity(queryWrapper);
         if ("0".equals(user.getIsKefu())) {
-            user.setOnlineType("0");
-            userService.update(user);
+//            user.setOnlineType("0");
+//            userService.update(user);
+            User up=new User();
+            up.setOnlineType("0");
+            userService.updateBatch(up,queryWrapper);
             updateGroupQueue();
             return Success("置闲成功");
         }

webapidemo-api/src/main/java/com/example/controller/wechat/WechatController.java

@@ -16,6 +16,7 @@ import com.example.service.system.IUserService;
 import com.example.service.webScoket.WebSocket;
 import com.example.util.helper.FileUtil;
 import com.example.util.helper.RedisHelper;
+import com.example.util.helper.StringHelper;
 import com.thoughtworks.xstream.XStream;
 import me.chanjar.weixin.common.api.WxConsts;
 import me.chanjar.weixin.common.bean.result.WxMediaUploadResult;
@@ -228,7 +229,7 @@ public class WechatController extends BaseController {
             LambdaQueryWrapper<CustomerInfo> qw = new LambdaQueryWrapper<>();
             qw.eq(CustomerInfo::getOpenId, id);
             CustomerInfo customerInfo = customerInfoService.getEntity(qw);
-            if (custName != null && !customerInfo.getCustName().contains(custName)) {
+            if (customerInfo==null ||(customerInfo != null&& StringHelper.isNotEmpty(custName) && !customerInfo.getCustName().contains(custName))) {
                 continue;
             }
             Query query = new Query(Criteria.where("openId").is(id));
@@ -256,14 +257,84 @@ public class WechatController extends BaseController {
      */
     @GetMapping("/kefu/mongodbMessage/{openId}")
     public AjaxResult getChatHistory(@PathVariable String openId) {
+        Long userId = CurrentUser().getUserId();
         Query query = new Query(Criteria.where("openId").is(openId));
         List<MongoDBMessage> mongoDBMessages = mongoTemplate.find(query, MongoDBMessage.class);
+
+        if(mongoDBMessages.stream().filter(p->p.getReadMessage().equals(1)).count()>0) {
+            query.addCriteria(Criteria.where("readMessage").is(1));
+            Update update = new Update();
+            update.set("readMessage", 0);
+            update.set("kefuId", userId);
+            this.mongoTemplate.updateMulti(query, update, MongoDBMessage.class);
+        }
+
+        return Success("操作成功!", mongoDBMessages);
+    }
+
+    /**
+     * mongodb保存的聊天记录
+     * @return
+     */
+    @GetMapping("/kefu/leaveword/{openId}")
+    public AjaxResult getLeaveWord(@PathVariable String openId) {
+        Query query = new Query(Criteria.where("openId").is(openId).and("kefuId").is(0));
+        Long n = this.mongoTemplate.count(query, MongoDBMessage.class);
+        if (n == 0L) {
+            return Error("其他客服已经接入");
+        }
+        Long userId = CurrentUser().getUserId();
+        List<MongoDBMessage> mongoDBMessages = mongoTemplate.find(query, MongoDBMessage.class);
         Update update = new Update();
         update.set("readMessage", 0);
+        update.set("kefuId", userId);
         this.mongoTemplate.updateMulti(query, update, MongoDBMessage.class);
         return Success("操作成功!", mongoDBMessages);
     }
 
+    /**
+     * 获取留言列表
+     * @return
+     */
+    @GetMapping("/kefu/leaveword")
+    public AjaxResult getLeaveWordList(@RequestParam(value = "custName", required = false) String custName) {
+        Long userId = CurrentUser().getUserId();
+        //分组
+        Aggregation agg = Aggregation.newAggregation(
+                //进行条件的筛选
+                Aggregation.match(Criteria.where("kefuId").is(0L)),
+                //针对某一个字段分组
+                Aggregation.group("openId").count().as("count"),
+                Aggregation.project("count")
+        );
+        AggregationResults<Map> aggregationResults = mongoTemplate.aggregate(agg, MongoDBMessage.class, Map.class);
+        List<Map> list = aggregationResults.getMappedResults();
+        List<SocketVo> socketVoList = new ArrayList<>();
+        for (Map map : list) {
+            String id = map.get("_id").toString();
+
+            LambdaQueryWrapper<CustomerInfo> qw = new LambdaQueryWrapper<>();
+            qw.eq(CustomerInfo::getOpenId, id);
+            CustomerInfo customerInfo = customerInfoService.getEntity(qw);
+            if (customerInfo==null ||(customerInfo != null&& StringHelper.isNotEmpty(custName) && !customerInfo.getCustName().contains(custName))) {
+                continue;
+            }
+            Query query = new Query(Criteria.where("openId").is(id));
+            query.with(Sort.by(Sort.Order.desc("_id"))).limit(1);
+            MongoDBMessage templateOne = mongoTemplate.findOne(query, MongoDBMessage.class);
+
+            SocketVo socketVo = new SocketVo();
+            socketVo.setCustId(customerInfo.getCustId());
+            socketVo.setOpenId(customerInfo.getOpenId());
+            socketVo.setCustName(customerInfo.getCustName());
+            socketVo.setCustChannel(customerInfo.getCustChannel());
+            socketVo.setSendTime(templateOne.getSendDate());
+            socketVo.setContent(templateOne.getContent());
+            socketVo.setUnreadMessageCount(Long.parseLong(map.get("count").toString()) );
+            socketVoList.add(socketVo);
+        }
+        return Success("成功!", socketVoList);
+    }
 
     /**
      * 获取文件类型

webapidemo-api/src/main/resources/application-dev.yml

@@ -48,15 +48,6 @@ spring:
             type: round_robin
     enabled: true
 
-  data:
-    mongodb:
-      authentication-database: admin
-      host: 192.168.5.44
-      port: 27017
-      database: jiayi
-      username: root
-      password: '123456'
-
   redis:
     # 地址
     host: 192.168.1.200
@@ -68,6 +59,16 @@ spring:
     password:
     # 连接超时时间
     timeout: 10s
+
+  data:
+    mongodb:
+      authentication-database: admin
+      host: 192.168.5.44
+      port: 27017
+      database: jiayi
+      username: root
+      password: '123456'
+
   rabbitmq:
     host: 192.168.1.200
     port: 5672
@@ -89,7 +90,7 @@ spring:
     #        auto-startup: false
 
   wechat:
-    AppId: wx4ff77198ae11494b
-    AppSecret: 2142698972a706a651f371e412d48a78
-    Token: wxtoken
-    EncodingAESKey:
+    AppId: wx0d67bbb5666ec226
+    AppSecret: abe7ea3ac71e42fa27ec564045b1387a
+    Token: a3ac71e42f
+    EncodingAESKey: SnHmIXFhkuagAXcoAAEsgVnNiqFdn2TXkwT7Tm2MqkC

webapidemo-api/src/main/resources/application.yml

@@ -3,8 +3,8 @@ spring:
     date-format: yyyy-MM-dd HH:mm:ss
     time-zone: GMT+8
   profiles:
-    active: production
-    #active: dev
+    #active: production
+    active: dev
 
   resources:
     static-locations: file:/home/website/webapidemo/Api/file/image/  #资源路径

webapidemo-api/src/test/java/TestDate/TestDateInput.java

@@ -1,271 +0,0 @@
-package TestDate;
-
-import com.alibaba.fastjson2.JSON;
-import com.alibaba.fastjson2.JSONObject;
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.example.WebApiApplication;
-import com.example.entity.database.system.Menu;
-import com.example.entity.database.system.User;
-import com.example.entity.view.system.GroupLogins;
-import com.example.service.rabbitmqListener.Consumer;
-import com.example.service.rabbitmqListener.PicDownload;
-import com.example.service.system.IMenuService;
-import com.example.service.system.IUserService;
-import com.example.service.webScoket.WebSocket;
-import com.example.util.config.RabbitConfig;
-import com.example.util.config.WxMpConfig;
-import com.example.util.helper.RedisHelper;
-import com.rabbitmq.client.Channel;
-import com.rabbitmq.client.Connection;
-import com.rabbitmq.client.GetResponse;
-import me.chanjar.weixin.common.error.WxErrorException;
-import me.chanjar.weixin.mp.api.WxMpService;
-import me.chanjar.weixin.mp.bean.kefu.WxMpKefuMessage;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.springframework.amqp.rabbit.core.RabbitTemplate;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.data.mongodb.core.MongoTemplate;
-import org.springframework.test.context.junit4.SpringRunner;
-import org.springframework.web.context.request.RequestContextHolder;
-import org.springframework.web.socket.WebSocketSession;
-
-import java.io.*;
-import java.net.URL;
-import java.net.URLConnection;
-import java.nio.charset.StandardCharsets;
-import java.text.SimpleDateFormat;
-import java.util.*;
-
-@SpringBootTest(classes = WebApiApplication.class)
-@RunWith(SpringRunner.class)
-public class TestDateInput {
-    @Autowired
-    public IMenuService menuService;
-    @Autowired
-    public WxMpService wxMpService;
-    @Autowired
-    public RedisHelper redisHelper;
-    @Autowired
-    public RabbitTemplate rabbitTemplate;
-    @Autowired
-    public Consumer consumer;
-    @Autowired
-    public MongoTemplate mongoTemplate;
-    @Autowired
-    private WebSocket webSocket;
-    @Autowired
-    private IUserService userService;
-    @Test
-    public void test1() {
-        Calendar oldCal = Calendar.getInstance();
-        oldCal.setTime(new Date());
-        oldCal.add(2, -1);
-
-        Calendar nowCal = Calendar.getInstance();
-        nowCal.setTime(new Date());
-        System.out.println(nowCal.after(oldCal));
-        if (nowCal.after(oldCal)) {
-            System.out.println(true);
-        } else {
-            System.out.println(false);
-        }
-
-
-    }
-
-    @Test
-    public void test2() {
-        List<Menu> menus = menuService.selectMenuTreeByUserId(2l);
-        System.out.println(menus);
-    }
-
-    @Test
-    public void test3() {
-        String cache = redisHelper.getCache("orR6E6l4wDixgeO8iaDetMoeb3hs");
-        System.out.println(cache);
-    }
-
-    @Test
-    public void test223() {
-        LambdaQueryWrapper<User> qw = new LambdaQueryWrapper<>();
-        qw.eq(User::getUserId,"1");
-        User entity = userService.getEntity(qw);
-        System.out.println(entity);
-    }
-
-
-    @Test
-    public void test222() {
-
-        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-        //String format = simpleDateFormat.format(createTime);
-    }
-
-    @Test
-    public void Test777() throws IOException {
-        //创建连接
-        Connection connection = RabbitConfig.getConnection();
-        //创建消息信道
-        Channel channel = connection.createChannel();
-        GetResponse groupQueue = channel.basicGet("group_queue", true);
-        String groupMessage = new String(groupQueue.getBody());
-        GroupLogins groupLogins = JSON.parseObject(groupMessage, GroupLogins.class);
-        Long workNumber = groupLogins.getWorkNumber();
-
-        Map<String, Object> map = new HashMap<>();
-        map.put("id", groupLogins.getId());
-        map.put("userName", groupLogins.getUserName());
-        map.put("workNumber", groupLogins.getWorkNumber());
-        map.put("status", groupLogins.getStatus());
-        rabbitTemplate.convertAndSend("group_queue", map);
-    }
-
-    @Test
-    public void test66() {
-        Map<String, Object> map = new HashMap<>();
-        map.put("id", "1");
-        map.put("type", "1");
-        map.put("formUser", "1");
-        map.put("appId", "1");
-        map.put("openId", "1");
-        map.put("sendTime", 1);
-        map.put("content", "1");
-        rabbitTemplate.convertAndSend("message_queue", map);
-    }
-
-    @Test
-    public void Test() {
-        WxMpKefuMessage message = WxMpKefuMessage.TEXT().toUser("orR6E6l4wDixgeO8iaDetMoeb3hs").content("content").build();
-        try {
-            wxMpService.getKefuService().sendKefuMessage(message);
-        } catch (WxErrorException e) {
-            e.printStackTrace();
-        }
-    }
-    @Test
-    public void Teswdadt() {
-        Set<WebSocketSession> sessions = webSocket.getSessions();
-        System.out.println(sessions);
-    }
-
-    @Test
-    public void Test2() {
-        //String cache = redisHelper.getCache("onLineKefu");
-        //JSONObject jsonObject = JSON.parseObject(cache);
-        //UserView userView = new UserView();
-        List<GroupLogins> groupLoginsList = new ArrayList<>();
-        GroupLogins groupLogins = new GroupLogins();
-        groupLogins.setWorkNumber(1l);
-        groupLogins.setUserName("admin");
-        groupLogins.setStatus("0");
-        groupLoginsList.add(groupLogins);
-        //userView.setGroupLogins(groupLoginsList);
-        redisHelper.setCache("onLineKefu", JSON.toJSONString(groupLoginsList));
-    }
-
-    @Test
-    public void Test3() {
-        String cache = redisHelper.getCache("onLineKefu");
-        List<GroupLogins> groupLoginsList = JSON.parseArray(cache, GroupLogins.class);
-        System.out.println(groupLoginsList);
-        //UserView userView = new UserView();
-        GroupLogins groupLogins = new GroupLogins();
-        groupLogins.setWorkNumber(2l);
-        groupLogins.setUserName("admindd");
-        groupLogins.setStatus("0");
-        groupLoginsList.add(groupLogins);
-        //userView.setGroupLogins(groupLoginsList);
-        redisHelper.setCache("onLineKefu", JSON.toJSONString(groupLoginsList));
-    }
-
-    @Test
-    public void Tes222t() {
-        File file = null;
-        try {
-            file = wxMpService.getMaterialService().mediaDownload("sFooQ4TojSWPTePnfYo3eQmsJbBU1mdfLAxucQkg5RPaFeQWwcvr19TpCZIHz3lq");
-            System.out.println(file);
-        } catch (WxErrorException e) {
-            e.printStackTrace();
-        }
-    }
-
-
-    @Test
-    public void Tes22222t() {
-        File file = null;
-        try {
-            file = wxMpService.getMaterialService().mediaDownload("sFooQ4TojSWPTePnfYo3eQmsJbBU1mdfLAxucQkg5RPaFeQWwcvr19TpCZIHz3lq");
-            System.out.println(file);
-        } catch (WxErrorException e) {
-            e.printStackTrace();
-        }
-    }
-
-    @Test
-    public void Tes22222wwt() {
-        WxMpConfig wxMpConfig = new WxMpConfig();
-        String accessTokenMethod = getAccessTokenMethod(wxMpConfig.wxMpDefaultConfigImpl().getAppId(), wxMpConfig.wxMpDefaultConfigImpl().getSecret());
-        System.out.println(accessTokenMethod);
-    }
-
-    @Test
-    public void Tes22222222wwt() {
-        Object currentUser = RequestContextHolder.getRequestAttributes().getAttribute("CurrentUser", 0);
-        System.out.println(currentUser);
-    }
-
-    @Test
-    public void Tes22www222wwt() throws IOException {
-        WxMpConfig wxMpConfig = new WxMpConfig();
-        String accessTokenMethod = getAccessTokenMethod(wxMpConfig.wxMpDefaultConfigImpl().getAppId(), wxMpConfig.wxMpDefaultConfigImpl().getSecret());
-        InputStream inputStream = PicDownload.fetchTmpFile("E5Jzo_ybkPFXDHIrCMjubZU8I_47YaUpPoreV7DsBWZHFOmz1sWj9w9X3YO4lB26", "image", accessTokenMethod);
-        byte[] flash = new byte[inputStream.available()];
-        inputStream.read(flash);
-        //二进制转化为图片
-        try (FileOutputStream fileOutputStream = new FileOutputStream(new File("C:/Users/2.jpg"));) {
-            fileOutputStream.write(flash);
-        } catch (IOException e) {
-            e.printStackTrace();
-        }
-    }
-
-
-    /**
-     * 获取AccessToken
-     *
-     * @param appId     填写公众号的appid
-     * @param appSecret 填写公众号的开发者密码(AppSecret)
-     * @return
-     */
-    public String getAccessTokenMethod(String appId, String appSecret) {
-        try {
-            String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" +
-                    appId + "&secret=" + appSecret;
-
-            StringBuilder json = new StringBuilder();
-            URL oracle = new URL(url);
-            URLConnection yc = oracle.openConnection();
-            BufferedReader in = new BufferedReader(new InputStreamReader(yc.getInputStream(), StandardCharsets.UTF_8));
-            String inputLine = null;
-            while ((inputLine = in.readLine()) != null) {
-                json.append(inputLine);
-            }
-            in.close();
-            JSONObject object = (JSONObject) JSONObject.parse(String.valueOf(json));
-            //log.info(title + "==>" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + "获取access_token:{}", object.getString("access_token"));
-            if (object.getString("access_token") != null) {
-
-                return object.getString("access_token");
-            }
-            return null;
-
-        } catch (Exception e) {
-            // log.error("获取accessToken异常" + e.getMessage());
-            return null;
-        }
-    }
-
-
-}

webapidemo-api/src/test/resources/webSecoket.html

@@ -1,83 +0,0 @@
-<!DOCTYPE html>
-<html>
-
-<head>
-    <meta charset="utf-8">
-    <title>Java后端WebSocket的Tomcat实现</title>
-    <script src="https://cdn.bootcdn.net/ajax/libs/jquery/3.6.0/jquery.min.js"></script>
-</head>
-
-<body>
-<div id="message"></div>
-<hr />
-<div id="main"></div>
-<div id="client"></div>
-<input id="text" type="text" />
-<button onclick="send()">发送消息</button>
-<hr />
-<button onclick="closeWebSocket()">关闭WebSocket连接</button>
-</body>
-<script type="text/javascript">
-
-    var cid = Math.floor(Math.random() * 100); // 随机生成客户端id
-    document.getElementById('client').innerHTML += "客户端 id = " + cid + '<br/>';
-
-    var websocket = null;
-
-    //判断当前浏览器是否支持WebSocket
-    if ('WebSocket' in window) {
-        // 改成你的地址
-        websocket = new WebSocket("ws://127.0.0.1:8000/websocket/" + cid);
-    } else {
-        alert('当前浏览器 Not support websocket')
-    }
-
-    //连接发生错误的回调方法
-    websocket.onerror = function () {
-        setMessageInnerHTML("websocket.onerror: WebSocket连接发生错误");
-    };
-
-    //连接成功建立的回调方法
-    websocket.onopen = function () {
-        setMessageInnerHTML("websocket.onopen: WebSocket连接成功");
-    }
-
-    //接收到消息的回调方法
-    websocket.onmessage = function (event) {
-        setMessageInnerHTML("websocket.onmessage: " + event.data);
-    }
-
-    //连接关闭的回调方法
-    websocket.onclose = function () {
-        setMessageInnerHTML("websocket.onclose: WebSocket连接关闭");
-    }
-
-    //监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。
-    window.onbeforeunload = function () {
-        closeWebSocket();
-    }
-
-    //将消息显示在网页上
-    function setMessageInnerHTML(innerHTML) {
-        document.getElementById('message').innerHTML += innerHTML + '<br/>';
-    }
-
-    //关闭WebSocket连接
-    function closeWebSocket() {
-        websocket.close();
-        alert('websocket.close: 关闭websocket连接')
-    }
-
-    //发送消息
-    function send() {
-        var message = document.getElementById('text').value;
-        try {
-            websocket.send('{"msg":"' + message + '"}');
-            setMessageInnerHTML("websocket.send: " + message);
-        } catch (err) {
-            console.error("websocket.send: " + message + " 失败");
-        }
-    }
-</script>
-
-</html>

webapidemo-service/src/main/java/com/example/service/rabbitmqListener/Consumer.java

@@ -181,7 +181,7 @@ public class Consumer {
         LambdaQueryWrapper<CustomerInfo> queryWrapper = new LambdaQueryWrapper<>();
         queryWrapper.eq(CustomerInfo::getOpenId, openId);
 
-        if (customerInfoService.getList(queryWrapper) == null) {
+        if (customerInfoService.getCount(queryWrapper) == 0) {
             CustomerInfo customerInfo = new CustomerInfo();
             customerInfo.setOpenId(openId);
             customerInfoService.insert(customerInfo);
@@ -331,9 +331,10 @@ public class Consumer {
             mongoDBMessage.setFromUser(queueMessage.getFormUser());
             saveMongoDB(queueMessage, mongoDBMessage, queueMessage.getKefuId());
             String mediaId = queueMessage.getMediaId();
+            String content = queueMessage.getContent();
             String msgType = queueMessage.getMsgType();
             if ("text".equals(msgType)) {
-                WxMpKefuMessage wechatMessage = WxMpKefuMessage.TEXT().toUser(queueMessage.getOpenId()).content(queueMessage.getContent().toString()).build();
+                WxMpKefuMessage wechatMessage = WxMpKefuMessage.TEXT().toUser(queueMessage.getOpenId()).content(content).build();
                 wxMpService.getKefuService().sendKefuMessage(wechatMessage);
             } else if ("video".equals(msgType)) {
                 WxMpKefuMessage wechatMessage = WxMpKefuMessage.VIDEO().toUser(queueMessage.getOpenId()).mediaId(mediaId).build();
@@ -345,6 +346,7 @@ public class Consumer {
                 mongoDBMessage.setPicUrl(queueMessage.getPicUrl());
             }
         } catch (Exception e) {
+            log.error("微信客服发送消息失败",e);
             e.printStackTrace();
         }
     }

webapidemo-service/src/main/java/com/example/service/webScoket/impl/WebSocketImpl.java

@@ -2,9 +2,17 @@ package com.example.service.webScoket.impl;
 
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.example.entity.database.system.User;
+import com.example.entity.view.system.GroupLogins;
 import com.example.entity.view.system.QueueMessage;
+import com.example.service.system.IUserService;
 import com.example.service.webScoket.WebSocket;
+import com.example.util.config.RabbitConfig;
 import com.example.util.helper.RedisHelper;
+import com.example.util.helper.SnowFlakeUtil;
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.Connection;
 import lombok.extern.slf4j.Slf4j;
 import me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl;
 import org.apache.tomcat.util.threads.ThreadPoolExecutor;
@@ -38,6 +46,8 @@ public class WebSocketImpl implements WebSocket {
     private RedisHelper redisHelper;
     @Autowired
     private MongoTemplate mongoTemplate;
+    @Autowired
+    private IUserService userService;
     /**
      * 在线连接数（线程安全）
      */
@@ -61,7 +71,56 @@ public class WebSocketImpl implements WebSocket {
         int count = connectionCount.decrementAndGet();
         Map<String, Object> attributes = session.getAttributes();
         String userId = (String) attributes.get("userId");
-        redisHelper.deleteCache(userId);
+        LambdaQueryWrapper<User> qw = new LambdaQueryWrapper<>();
+        qw.eq(User::getUserId, userId);
+        User user = userService.getEntity(qw);
+        if ("0".equals(user.getIsKefu())) {
+//            user.setOnlineType("2");
+//            userService.update(user);
+            User up=new User();
+            up.setOnlineType("2");
+            userService.updateBatch(up,qw);
+            String queueName = "kefu_" + userId;
+            Set<String> keys = redisHelper.getSetKeys(queueName + "*");
+            redisHelper.deleteCache(keys);
+
+            LambdaQueryWrapper<User> online = new LambdaQueryWrapper<>();
+            online.eq(User::getIsKefu, "0");
+            online.eq(User::getOnlineType, "0");
+            List<User> userList = userService.getList(online);
+            List<GroupLogins> groupLoginsList = new ArrayList<>();
+            SnowFlakeUtil snowFlakeUtil = new SnowFlakeUtil(10, 12);
+            Long nextId = snowFlakeUtil.getNextId();
+            for (User onlineUser : userList) {
+                GroupLogins groupLogins = new GroupLogins();
+                groupLogins.setId(nextId);
+                groupLogins.setWorkNumber(onlineUser.getUserId());
+                groupLogins.setUserName(onlineUser.getUserName());
+                groupLogins.setStatus(onlineUser.getStatus());
+                groupLoginsList.add(groupLogins);
+            }
+
+            redisHelper.deleteCache("onlineKefu");
+            redisHelper.setCache("onlineKefu", JSON.toJSONString(groupLoginsList));
+            //创建连接
+            Connection connection = RabbitConfig.getConnection();
+            //创建消息信道
+            Channel channel = null;
+            try {
+                channel = connection.createChannel();
+                channel.queuePurge("group_queue");
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+            for (User onlineUser : userList) {
+                Map<String, Object> map = new HashMap<>();
+                map.put("id", nextId);
+                map.put("workNumber", onlineUser.getUserId());
+                map.put("userName", onlineUser.getUserName());
+                map.put("status", onlineUser.getStatus());
+                rabbitTemplate.convertAndSend("group_queue", map);
+            }
+        }
         log.info("a new connection closed，current online count：{}", count);
     }
 

webapidemo-util/src/main/java/com/example/util/config/RabbitConfig.java

@@ -17,15 +17,28 @@ import org.springframework.context.annotation.Configuration;
 public class RabbitConfig {
 
     @Value("${spring.rabbitmq.host}")
+    private void setHost(String param){
+        host=param;
+    }
     private static String host;
     @Value("${spring.rabbitmq.port}")
+    private void setPort(int param){
+        port=param;
+    }
     private static int port;
     @Value("${spring.rabbitmq.username}")
+    private void setUsername(String param){
+        username=param;
+    }
     private static String username;
     @Value("${spring.rabbitmq.password}")
+    private void setPassword(String param){
+        password=param;
+    }
     private static String password;
 
     public static Connection getConnection() {
+        System.out.println(host);
         Connection connection = null;
         try {
             ConnectionFactory factory = new ConnectionFactory();