From b6b4fddb128636de774403716b5a3b070d077868 Mon Sep 17 00:00:00 2001
From: wen <1455474577@qq.com>
Date: Wed, 9 Feb 2022 16:43:51 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=B0=8F=E7=A8=8B=E5=BA=8F?=
 =?UTF-8?q?=E7=BA=A2=E7=82=B9=E4=B8=8D=E6=B6=88=E5=A4=B1=E7=9A=84=E9=97=AE?=
 =?UTF-8?q?=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../board/service/impl/XhpcMessageBoardServiceImpl.java     | 6 ++++++
 1 file changed, 6 insertions(+)

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 900af764..a3258b24 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
@@ -235,6 +235,12 @@ public class XhpcMessageBoardServiceImpl implements XhpcMessageBoardService {
         //处理下次查询时间
         response.setNextQueryTime(nextTimeStr);
         response.setData(dataDTOS);
+        //获取redis中用户未读信息数量，将其置为null
+        String userNotReadCount = "userNotReadMessageCount:" + userQueryCondition.getSenderType() + ":" + userQueryCondition.getSenderAccount() + ":" + "0:" + userQueryCondition.getTenantId();
+        Object cacheObject = redisService.getCacheObject(userNotReadCount);
+        if (cacheObject != null) {
+            redisService.deleteObject(userNotReadCount);
+        }
         return response;
     }