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 { * @param userIds */ void publishMessage(MessageEntity message, boolean toAllUser, List 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 LambdaUpdateWrapper 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 }); userMessageService.saveBatch(userMessageEntities); } + + @Override + public ResponseMessage readMessage(String id) { + LambdaUpdateWrapper lambdaUpdateWrapper = new LambdaUpdateWrapper<>(); + lambdaUpdateWrapper.eq(UserMessageEntity::getId, id); + lambdaUpdateWrapper.set(UserMessageEntity::getReadType, READ); + userMessageService.update(lambdaUpdateWrapper); + return Result.success(); + } }