优化查询sql 小程序未读消息数量通过websocket获取

src/main/java/com/dd/admin/business/chat/mapper/xml/ChatMapper.xml

@@ -63,7 +63,7 @@
         select * from (
             SELECT
                 a.FROM_ID AS authorId,
-                a.FROM_NAME AS authorName,
+                b.AUTHOR_NAME AS authorName,
                 b.AVATAR_URL AS authorAvatar,
                 a.content,
                 a.create_time,
@@ -90,7 +90,7 @@
 
             SELECT
                 a.TO_ID AS authorId,
-                a.TO_NAME AS authorName,
+                b.AUTHOR_NAME AS authorName,
                 b.AVATAR_URL AS authorAvatar,
                 a.content,
                 a.create_time,

src/main/java/com/dd/admin/business/webSocket/handler/GetApiReadCountMessageHandler.java

@@ -0,0 +1,50 @@
+package com.dd.admin.business.webSocket.handler;
+
+import com.dd.admin.business.api.domain.UnReadCountBean;
+import com.dd.admin.business.author.service.AuthorService;
+import com.dd.admin.business.chat.service.ChatService;
+import com.dd.admin.business.follow.service.FollowService;
+import com.dd.admin.business.reply.service.ReplyService;
+import com.dd.admin.business.starNotes.service.StarNotesService;
+import com.dd.admin.business.upNotes.service.UpNotesService;
+import com.dd.admin.business.webSocket.MsgHandlerInterface;
+import com.dd.admin.business.webSocket.util.TioUtil;
+import io.swagger.annotations.ApiModel;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.tio.core.ChannelContext;
+
+import java.util.Map;
+
+
+@Slf4j
+@Service("9")
+@ApiModel("获取未读总数Handler")
+public class GetApiReadCountMessageHandler implements MsgHandlerInterface {
+    @Autowired
+    ChatService chatService;
+    @Autowired
+    UpNotesService upNotesService;
+    @Autowired
+    StarNotesService starNotesService;
+    @Autowired
+    ReplyService replyService;
+    @Autowired
+    FollowService followService;
+    @Override
+    public Object handler(Map map, ChannelContext context) {
+        String authorId = String.valueOf(map.get("authorId"));
+        Integer chatUnReadCount = chatService.selectUnReadCount(authorId);
+        Integer upNotesUnReadCount = upNotesService.selectUnReadCount(authorId);
+        Integer starNotesUnReadCount = starNotesService.selectUnReadCount(authorId);
+        Integer replyUnReadCount = replyService.selectUnReadCount(authorId);
+        Integer followUnReadCount = followService.selectUnReadCount(authorId);
+        Integer totalUnReadCount = 0;
+        UnReadCountBean unReadCountBean = new UnReadCountBean(chatUnReadCount,upNotesUnReadCount,starNotesUnReadCount,replyUnReadCount,followUnReadCount,totalUnReadCount);
+        unReadCountBean.calculateTotalUnReadCount();
+
+        TioUtil.sendChatMessageToUser(context.getGroupContext(),authorId,"9",unReadCountBean);
+        return null;
+    }
+}

web/src/views/business/operationLog/operationLogList.vue

@@ -83,6 +83,17 @@
             </template>
           </el-table-column>
 
+
+          <el-table-column
+            label="操作时间"
+            width="160"
+            align="center"
+          >
+            <template slot-scope="scope">
+              {{ scope.row.createTime }}
+            </template>
+          </el-table-column>
+
             <el-table-column
                     label="请求模块"
                     width="160"
@@ -165,15 +176,6 @@
                 </template>
             </el-table-column>
 
-            <el-table-column
-                    label="操作时间"
-                    width="160"
-                    align="center"
-            >
-                <template slot-scope="scope">
-                    {{ scope.row.createTime }}
-                </template>
-            </el-table-column>
 
 
 

web/src/views/common/Im.vue

@@ -82,7 +82,6 @@
         });
         this.contact = contact
         contact.page = 1
-        contact.chatList = []
         //读取当前用户信息
         this.readAuthorMessage(contact.id)
         //获取总未读消息
@@ -140,8 +139,6 @@
           //倒序查询但是正序排列 时间早的在前面
           this.contact.totalPage = res.data.pages
           const messages = res.data.records
-
-          this.contact.chatList.push(... res.data.records.reverse());
           //当前页数小于等于总页数
           if(this.contact.page<=res.data.pages){
             //等于1时执行页面滚动操作