diff --git a/xhpc-modules/xhpc-message-board/src/main/java/com/xhpc/board/service/XhpcMessageBoardService.java b/xhpc-modules/xhpc-message-board/src/main/java/com/xhpc/board/service/XhpcMessageBoardService.java index 9d7a7010..089173e7 100644 --- a/xhpc-modules/xhpc-message-board/src/main/java/com/xhpc/board/service/XhpcMessageBoardService.java +++ b/xhpc-modules/xhpc-message-board/src/main/java/com/xhpc/board/service/XhpcMessageBoardService.java @@ -68,7 +68,7 @@ public interface XhpcMessageBoardService { QueryUserListResponse queryUserList(QueryUserListRequest param) throws Exception; /** - * 平台查询用户发送过来的信息,与用户查看它自己的信息一致 + * 平台查询用户发送过来的信息,与用户查看它自己的信息逻辑是一致的 * * @param userQueryCondition 要查询的用户的信息 * @return 返回用户与平台用户的一个月的聊天记录 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 a0c7558a..74c13b8e 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 @@ -154,7 +154,15 @@ public class XhpcMessageBoardServiceImpl implements XhpcMessageBoardService { platformRequest.setTenantId(sysUser.getTenantId()); platformRequest.setTenantType(0); messageBoardMapper.insertPlatformMessage(platformRequest); - + //往Redis中放置用户未读数量 + String userNotReadCount = "userNotReadMessageCount:" + platformRequest.getSenderType() + ":" + platformRequest.getSenderAccount() + ":" + "0:" + sysUser.getTenantId(); + Object cacheObject1 = redisService.getCacheObject(userNotReadCount); + if (cacheObject1 == null) { + redisService.setCacheObject(userNotReadCount, 1); + } else { + Integer userNotReadNum = (Integer) cacheObject1 + 1; + redisService.setCacheObject(userNotReadCount, userNotReadNum); + } } /**