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