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 88e0d033..91d0686d 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 @@ -61,13 +61,13 @@ public class XhpcMessageBoardServiceImpl implements XhpcMessageBoardService { //使用Redis判断消息发送是否大于5分钟: Object cacheObject = redisService.getCacheObject(userRedisKey); String currentTime; + String platformRedisKey = "PlatformMessageValidTime:" + userMessage.getTenantType() + ":" + userMessage.getTenantId() + ":" + loginUser.getUserType() + ":" + loginUser.getUsername(); if (cacheObject == null) { //设置当前时间 currentTime = DateUtil.getYyyyMmDdHhMmSs(); redisService.setCacheObject(userRedisKey, currentTime); redisService.expire(userRedisKey, 60 * 5); //设置平台RedisKey的有效时间,保证双方时间数据同步 - String platformRedisKey = "PlatformMessageValidTime:" + userMessage.getTenantType() + ":" + userMessage.getTenantId() + ":" + loginUser.getUserType() + ":" + loginUser.getUsername(); redisService.setCacheObject(platformRedisKey, currentTime); redisService.expire(platformRedisKey, 60 * 5); userMessage.setSendMessageTime(currentTime); @@ -92,6 +92,7 @@ public class XhpcMessageBoardServiceImpl implements XhpcMessageBoardService { } else { //reset redis key valid time redisService.expire(userRedisKey, 60 * 5); + redisService.expire(platformRedisKey, 60 * 5); currentTime = (String) cacheObject; userMessage.setSendMessageTime(currentTime); //设置用户账号,用户类型