From 253667aece4c93474e56c3fe4e722b0bc6658b2b Mon Sep 17 00:00:00 2001 From: wen <1455474577@qq.com> Date: Thu, 13 Jan 2022 18:59:55 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=B9=B3=E5=8F=B0=E7=BB=99?= =?UTF-8?q?=E7=94=A8=E6=88=B7=E5=8F=91=E9=80=81=E6=B6=88=E6=81=AF=E6=97=B6?= =?UTF-8?q?=E9=97=B4=E4=B8=8D=E5=90=8C=E6=AD=A5=E7=9A=84Bug=EF=BC=8C?= =?UTF-8?q?=E7=8E=B0=E5=B7=B2=E4=BD=BF=E5=8F=8C=E6=96=B9=E4=BB=BB=E6=84=8F?= =?UTF-8?q?=E4=B8=80=E6=96=B9=E5=8F=91=E9=80=81=E6=B6=88=E6=81=AF=EF=BC=8C?= =?UTF-8?q?=E9=83=BD=E4=BC=9A=E4=BD=BF=E5=BE=97Redis=E4=B8=AD=E7=9A=84key?= =?UTF-8?q?=E7=9A=84=E6=9C=89=E6=95=88=E6=97=B6=E9=97=B4=E9=87=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../xhpc/board/controller/XhpcMessageBoardController.java | 7 +++++++ .../board/service/impl/XhpcMessageBoardServiceImpl.java | 6 ++++-- 2 files changed, 11 insertions(+), 2 deletions(-) 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"; }