From eccef949112bb033dc1a08d57de5b09f251e15c1 Mon Sep 17 00:00:00 2001
From: yanglin <yanglin@test.foo>
Date: Thu, 9 May 2024 14:21:49 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A41=E5=91=A8=E5=89=8D=E6=97=A0?=
 =?UTF-8?q?=E7=94=A8=E7=9A=84im=20task=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/cn/axzo/im/controller/PrivateController.java    | 9 +++++++++
 .../src/main/java/cn/axzo/im/job/ExpungeImTaskJob.java   | 7 ++++++-
 2 files changed, 15 insertions(+), 1 deletion(-)

diff --git a/im-center-server/src/main/java/cn/axzo/im/controller/PrivateController.java b/im-center-server/src/main/java/cn/axzo/im/controller/PrivateController.java
index 0a9545c..9d4f651 100644
--- a/im-center-server/src/main/java/cn/axzo/im/controller/PrivateController.java
+++ b/im-center-server/src/main/java/cn/axzo/im/controller/PrivateController.java
@@ -6,10 +6,12 @@ import cn.axzo.im.channel.netease.dto.QueryEventRequest;
 import cn.axzo.im.channel.netease.dto.QueryMessageRequest;
 import cn.axzo.im.channel.netease.dto.RevokeMessageRequest;
 import cn.axzo.im.job.CreateMessageHistoryJob;
+import cn.axzo.im.job.ExpungeImTaskJob;
 import cn.axzo.im.job.RevokeAllMessagesJob;
 import cn.axzo.im.job.SendMessageJob;
 import cn.axzo.im.job.UpdateImAccountOuIdJob;
 import cn.axzo.im.service.AccountRegisterService;
+import cn.azxo.framework.common.model.CommonResponse;
 import com.alibaba.fastjson.JSONObject;
 import lombok.RequiredArgsConstructor;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -33,6 +35,7 @@ public class PrivateController {
     private final SendMessageJob sendMessageJob;
     private final CreateMessageHistoryJob createMessageHistoryJob;
     private final MessageController messageController;
+    private final ExpungeImTaskJob expungeImTaskJob;
 
     @PostMapping("/private/revoke")
     public Object revoke(@Valid @RequestBody RevokeMessageRequest request) {
@@ -78,4 +81,10 @@ public class PrivateController {
     public Object sendMessage(@RequestBody SendMessageParam param) throws Exception {
         return messageController.sendMessage(param);
     }
+
+    @PostMapping("/private/message/expungeTask")
+    public Object expungeTask() {
+        int count = expungeImTaskJob.runWithDefault();
+        return CommonResponse.success(count);
+    }
 }
\ No newline at end of file
diff --git a/im-center-server/src/main/java/cn/axzo/im/job/ExpungeImTaskJob.java b/im-center-server/src/main/java/cn/axzo/im/job/ExpungeImTaskJob.java
index 9a7bfed..ace8d01 100644
--- a/im-center-server/src/main/java/cn/axzo/im/job/ExpungeImTaskJob.java
+++ b/im-center-server/src/main/java/cn/axzo/im/job/ExpungeImTaskJob.java
@@ -38,10 +38,15 @@ public class ExpungeImTaskJob extends IJobHandler {
         }
     }
 
-    private void executeImpl(Param param) {
+    public int runWithDefault() {
+        return executeImpl(new Param());
+    }
+
+    private int executeImpl(Param param) {
         Date until = DateTime.now().minusDays(param.daysAgo).toDate();
         int count = messageTaskMapper.expunge(until);
         log.info("deleted count={}", count);
+        return count;
     }
 
     @Data