From 8ac298b4cd859afa95214837198eb621ee411bbb Mon Sep 17 00:00:00 2001
From: dongyukun <1208714201@qq.com>
Date: 星期二, 10 六月 2025 10:14:41 +0800
Subject: [PATCH] 注销redisson配置
---
shasteel-biz/src/main/java/com/iailab/module/shasteel/api/controller/admin/MessageInfoController.java | 40 ++++++++++++++++++++++++++++++++++++++++
1 files changed, 40 insertions(+), 0 deletions(-)
diff --git a/shasteel-biz/src/main/java/com/iailab/module/shasteel/api/controller/admin/MessageInfoController.java b/shasteel-biz/src/main/java/com/iailab/module/shasteel/api/controller/admin/MessageInfoController.java
new file mode 100644
index 0000000..ab496fa
--- /dev/null
+++ b/shasteel-biz/src/main/java/com/iailab/module/shasteel/api/controller/admin/MessageInfoController.java
@@ -0,0 +1,40 @@
+package com.iailab.module.shasteel.api.controller.admin;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.iailab.framework.common.pojo.CommonResult;
+import com.iailab.framework.common.pojo.PageResult;
+import com.iailab.module.shasteel.job.entity.MessageInfoEntity;
+import com.iailab.module.shasteel.job.service.MessageInfoService;
+import io.swagger.v3.oas.annotations.Operation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+import static com.iailab.framework.common.pojo.CommonResult.success;
+
+@Slf4j
+@RestController
+@RequestMapping("/shasteel/api/message")
+public class MessageInfoController {
+
+ @Autowired
+ private MessageInfoService messageInfoService;
+
+ @GetMapping("/page")
+ public CommonResult<PageResult<MessageInfoEntity>> queryMessagePage(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize) {
+ PageResult<MessageInfoEntity> page = messageInfoService.getMessagePage(pageNo,pageSize);
+ return success(page);
+ }
+
+ @GetMapping("/count")
+ public long getUnreadMessageCount(){
+ return messageInfoService.getUnreadMessageCount();
+ }
+
+ @PostMapping("/read")
+ public void read(@RequestBody List<String> ids){
+ messageInfoService.readMessage(ids);
+ }
+}
--
Gitblit v1.9.3