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 9d4f651..8a65569 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 @@ -83,8 +83,8 @@ public class PrivateController { } @PostMapping("/private/message/expungeTask") - public Object expungeTask() { - int count = expungeImTaskJob.runWithDefault(); + public Object expungeTask(@RequestBody(required = false) ExpungeImTaskJob.Param param) { + int count = expungeImTaskJob.expunge(param); 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 ace8d01..d201266 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 @@ -29,7 +29,7 @@ public class ExpungeImTaskJob extends IJobHandler { log.info("start - run job with param={}", paramStr); try { Param param = JSONObjectUtil.parseObject(paramStr, Param.class); - executeImpl(param); + expunge(param); log.info("end - run job with param={}", param); return ReturnT.SUCCESS; } catch (Exception e) { @@ -38,11 +38,8 @@ public class ExpungeImTaskJob extends IJobHandler { } } - public int runWithDefault() { - return executeImpl(new Param()); - } - - private int executeImpl(Param param) { + public int expunge(Param nullableParam) { + Param param = nullableParam == null ? new Param() : nullableParam; Date until = DateTime.now().minusDays(param.daysAgo).toDate(); int count = messageTaskMapper.expunge(until); log.info("deleted count={}", count);