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; }