From 091a91c4959b0a3e3f40903e29db2b46c9339e87 Mon Sep 17 00:00:00 2001
From: wen <1455474577@qq.com>
Date: Thu, 13 Jan 2022 19:21:17 +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=AB=AFredisKey=E6=9C=89=E6=95=88=E6=97=B6=E9=97=B4=E4=B8=8D?=
 =?UTF-8?q?=E5=90=8C=E6=AD=A5=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../xhpc/board/service/impl/XhpcMessageBoardServiceImpl.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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);
             //设置用户账号，用户类型