From 63cdb3251c44ac72682dcc56ed2b69b49050b2b9 Mon Sep 17 00:00:00 2001
From: Mzaxd <caihaohan0712@foxmail.com>
Date: Thu, 25 May 2023 17:51:01 +0800
Subject: [PATCH] =?UTF-8?q?fix:=E4=BF=AE=E5=A4=8DBug=E3=80=9069850?=
 =?UTF-8?q?=E3=80=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

站内信--点击查看后，当前条数据应该变成已读
---
 .../adc/da/report/controller/MessageController.java | 10 ++++++++++
 .../com/adc/da/report/service/IMessageService.java  |  7 +++++++
 .../da/report/service/impl/IMessageServiceImpl.java | 13 ++++++++++++-
 3 files changed, 29 insertions(+), 1 deletion(-)

diff --git a/adc-da-report/src/main/java/com/adc/da/report/controller/MessageController.java b/adc-da-report/src/main/java/com/adc/da/report/controller/MessageController.java
index 79c80a7..04fb5e4 100644
--- a/adc-da-report/src/main/java/com/adc/da/report/controller/MessageController.java
+++ b/adc-da-report/src/main/java/com/adc/da/report/controller/MessageController.java
@@ -46,4 +46,14 @@ public class MessageController {
         return messageEntityService.allRead();
     }
 
+    /**
+     * 已读
+     * @return
+     */
+    @ApiOperation("单条已读")
+    @GetMapping("/read/{id}")
+    public ResponseMessage readMessage(@PathVariable String id) {
+        return messageEntityService.readMessage(id);
+    }
+
 }
diff --git a/adc-da-report/src/main/java/com/adc/da/report/service/IMessageService.java b/adc-da-report/src/main/java/com/adc/da/report/service/IMessageService.java
index fe1016c..fbdbdaa 100644
--- a/adc-da-report/src/main/java/com/adc/da/report/service/IMessageService.java
+++ b/adc-da-report/src/main/java/com/adc/da/report/service/IMessageService.java
@@ -33,4 +33,11 @@ public interface IMessageService extends IService<MessageEntity> {
      * @param userIds
      */
     void publishMessage(MessageEntity message, boolean toAllUser, List<String> userIds);
+
+    /**
+     * 查看站内信设置为已读
+     * @param messageId
+     * @return
+     */
+    ResponseMessage readMessage(String messageId);
 }
diff --git a/adc-da-report/src/main/java/com/adc/da/report/service/impl/IMessageServiceImpl.java b/adc-da-report/src/main/java/com/adc/da/report/service/impl/IMessageServiceImpl.java
index a8987b9..4ea2c56 100644
--- a/adc-da-report/src/main/java/com/adc/da/report/service/impl/IMessageServiceImpl.java
+++ b/adc-da-report/src/main/java/com/adc/da/report/service/impl/IMessageServiceImpl.java
@@ -33,6 +33,8 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.stream.Collectors;
 
+import static com.adc.da.report.constant.MessageConstants.READ;
+
 /**
 * @author ThinkBook
 * @description 针对表【ts_message】的数据库操作Service实现
@@ -65,7 +67,7 @@ public class IMessageServiceImpl extends ServiceImpl<MessageDao, MessageEntity>
         LambdaUpdateWrapper<UserMessageEntity> wrapper = new LambdaUpdateWrapper<>();
         wrapper.eq(UserMessageEntity::getReadType, MessageConstants.UNREAD);
         wrapper.eq(UserMessageEntity::getUserId, UserUtils.getUserId());
-        wrapper.set(UserMessageEntity::getReadType, MessageConstants.READ);
+        wrapper.set(UserMessageEntity::getReadType, READ);
         userMessageService.update(wrapper);
         return Result.success("全部已读");
     }
@@ -101,6 +103,15 @@ public class IMessageServiceImpl extends ServiceImpl<MessageDao, MessageEntity>
         });
         userMessageService.saveBatch(userMessageEntities);
     }
+
+    @Override
+    public ResponseMessage readMessage(String id) {
+        LambdaUpdateWrapper<UserMessageEntity> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
+        lambdaUpdateWrapper.eq(UserMessageEntity::getId, id);
+        lambdaUpdateWrapper.set(UserMessageEntity::getReadType, READ);
+        userMessageService.update(lambdaUpdateWrapper);
+        return Result.success();
+    }
 }