diff --git a/xhpc-modules/xhpc-message-board/src/main/java/com/xhpc/board/controller/XhpcMessageBoardController.java b/xhpc-modules/xhpc-message-board/src/main/java/com/xhpc/board/controller/XhpcMessageBoardController.java
index 24c2b409..51afa483 100644
--- a/xhpc-modules/xhpc-message-board/src/main/java/com/xhpc/board/controller/XhpcMessageBoardController.java
+++ b/xhpc-modules/xhpc-message-board/src/main/java/com/xhpc/board/controller/XhpcMessageBoardController.java
@@ -24,6 +24,13 @@ public class XhpcMessageBoardController {
     @Resource
     XhpcMessageBoardService xhpcMessageBoardService;
 
+    /**
+     * 平台给用户发送消息
+     *
+     * @author WH
+     * @date 2022/1/13 18:43
+     * @since version-1.0
+     */
     @PostMapping("/platform/message")
     public AjaxResult platformSendMessageToUser(@RequestBody PlatformSendMessageToUserRequest platformRequest) {
 
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 51a78d6c..88e0d033 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
@@ -133,13 +133,13 @@ public class XhpcMessageBoardServiceImpl implements XhpcMessageBoardService {
         String platformRedisKey = "PlatformMessageValidTime:" + "0:" + sysUser.getTenantId() + ":" + platformRequest.getSenderType() + ":" + platformRequest.getSenderAccount();
         Object cacheObject = redisService.getCacheObject(platformRedisKey);
         String currentTime;
+        String userRedisKey = "userMessageValidTime:" + platformRequest.getSenderType() + ":" + platformRequest.getSenderAccount() + ":" + "0:" + sysUser.getTenantId();
         if (cacheObject == null) {
             //设置当前时间
             currentTime = DateUtil.getYyyyMmDdHhMmSs();
             redisService.setCacheObject(platformRedisKey, currentTime);
             redisService.expire(platformRedisKey, 60 * 5);
             //设置用户RedisKey的有效时间，保证双方时间数据同步
-            String userRedisKey = "userMessageValidTime:" + platformRequest.getSenderType() + ":" + platformRequest.getSenderAccount() + ":" + "0:" + sysUser.getTenantId();
             redisService.setCacheObject(userRedisKey, currentTime);
             redisService.expire(userRedisKey, 60 * 5);
             platformRequest.setSendMessageTime(currentTime);
@@ -150,10 +150,12 @@ public class XhpcMessageBoardServiceImpl implements XhpcMessageBoardService {
         }
         //reset redis key valid time
         redisService.expire(platformRedisKey, 60 * 5);
+        redisService.expire(userRedisKey, 60 * 5);
         platformRequest.setSendMessageTime((String) cacheObject);
         platformRequest.setTenantId(sysUser.getTenantId());
         platformRequest.setTenantType(0);
         messageBoardMapper.insertPlatformMessage(platformRequest);
+
     }
 
     /**
@@ -237,7 +239,7 @@ public class XhpcMessageBoardServiceImpl implements XhpcMessageBoardService {
      */
     @Override
     public String returnPlatformAvatar(String tenantId, Integer tenantType) {
-
+        //todo 查询数据库
         return "https://xhpc-bucket1.oss-cn-hangzhou.aliyuncs.com/avatar/logo.png";
     }