From f123c8b01b68297d8fbc49a5c5388269b66dafd1 Mon Sep 17 00:00:00 2001
From: wen <1455474577@qq.com>
Date: Sun, 16 Jan 2022 20:22:11 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8DBug=EF=BC=8C=E4=BD=BF?=
 =?UTF-8?q?=E7=95=99=E8=A8=80=E6=9D=BF=E7=BA=A2=E7=82=B9=E8=83=BD=E5=A4=9F?=
 =?UTF-8?q?=E6=AD=A3=E5=B8=B8=E6=B6=88=E5=A4=B1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mapper/XhpcMessageBoardReceiveUserMapper.java     | 11 +++++++++++
 .../service/impl/XhpcMessageBoardServiceImpl.java     |  4 +++-
 .../mapper/XhpcMessageBoardReceiveUserMapper.xml      |  9 +++++++++
 3 files changed, 23 insertions(+), 1 deletion(-)

diff --git a/xhpc-modules/xhpc-message-board/src/main/java/com/xhpc/board/mapper/XhpcMessageBoardReceiveUserMapper.java b/xhpc-modules/xhpc-message-board/src/main/java/com/xhpc/board/mapper/XhpcMessageBoardReceiveUserMapper.java
index 1ef5ad74..5ea339f4 100644
--- a/xhpc-modules/xhpc-message-board/src/main/java/com/xhpc/board/mapper/XhpcMessageBoardReceiveUserMapper.java
+++ b/xhpc-modules/xhpc-message-board/src/main/java/com/xhpc/board/mapper/XhpcMessageBoardReceiveUserMapper.java
@@ -2,6 +2,7 @@ package com.xhpc.board.mapper;
 
 import com.xhpc.board.domain.QueryUserListRequest;
 import com.xhpc.board.domain.SendMessageToPlatformRequest;
+import com.xhpc.board.domain.UserQueryCondition;
 import com.xhpc.board.pojo.XhpcMessageBoardReceiveUser;
 
 import java.util.List;
@@ -62,4 +63,14 @@ public interface XhpcMessageBoardReceiveUserMapper {
      */
     Long totalUserNumber(QueryUserListRequest param);
 
+    /**
+     * 消除留言板对应用户的红点
+     *
+     * @param userQueryCondition 用户信息
+     * @author WH
+     * @date 2022/1/16 20:13
+     * @since version-1.0
+     */
+    void updateHaveNewInfoIsNull(UserQueryCondition userQueryCondition);
+
 }
\ No newline at end of file
diff --git a/xhpc-modules/xhpc-message-board/src/main/java/com/xhpc/board/service/impl/XhpcMessageBoardServiceImpl.java b/xhpc-modules/xhpc-message-board/src/main/java/com/xhpc/board/service/impl/XhpcMessageBoardServiceImpl.java
index 74c13b8e..73047a9e 100644
--- a/xhpc-modules/xhpc-message-board/src/main/java/com/xhpc/board/service/impl/XhpcMessageBoardServiceImpl.java
+++ b/xhpc-modules/xhpc-message-board/src/main/java/com/xhpc/board/service/impl/XhpcMessageBoardServiceImpl.java
@@ -346,9 +346,11 @@ public class XhpcMessageBoardServiceImpl implements XhpcMessageBoardService {
             Long messageId = aMonthRecords.get(index).getMessageId();
             messageIdList.add(messageId);
         }
-        //设置查询出来的记录为已读状态，然后再查询，保证查询出来的是否有新信息状态被改变
+        //设置查询出来的记录为已读状态，然后再查询，保证查询出来的信息状态被改变
         messageBoardMapper.setUserReadedStatus(messageIdList);
         aMonthRecords = messageBoardMapper.selectBy(userQueryCondition, nextTimeStr);
+        //消除后台留言板红点
+        xhpcMessageBoardReceiveUserMapper.updateHaveNewInfoIsNull(userQueryCondition);
         //封装数据
         ArrayList<QueryUserMassageResponse.DataDTO> dataDTOS = new ArrayList<>();
         for (XhpcMessageBoard aMonthRecord : aMonthRecords) {
diff --git a/xhpc-modules/xhpc-message-board/src/main/resources/mapper/XhpcMessageBoardReceiveUserMapper.xml b/xhpc-modules/xhpc-message-board/src/main/resources/mapper/XhpcMessageBoardReceiveUserMapper.xml
index 0e15c7f5..dc5b5ff2 100644
--- a/xhpc-modules/xhpc-message-board/src/main/resources/mapper/XhpcMessageBoardReceiveUserMapper.xml
+++ b/xhpc-modules/xhpc-message-board/src/main/resources/mapper/XhpcMessageBoardReceiveUserMapper.xml
@@ -87,6 +87,15 @@
           AND sender_type = #{senderType}
           AND del_flag IS NULL;
     </update>
+    <update id="updateHaveNewInfoIsNull">
+        UPDATE xhpc_message_board_receive_user
+        SET have_new_info = null
+        WHERE tenant_type = #{tenantType}
+          AND tenant_id = #{tenantId}
+          AND sender_account = #{senderAccount}
+          AND sender_type = #{senderType}
+          AND del_flag IS NULL;
+    </update>
     <select id="findOneByCondition" resultMap="BaseResultMap">
         SELECT
         <include refid="Base_Column_List"/>