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 d201266..557bc63 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 @@ -1,6 +1,7 @@ package cn.axzo.im.job; import cn.axzo.im.dao.mapper.MessageTaskMapper; +import cn.axzo.im.utils.DateFormatUtil; import cn.axzo.im.utils.JSONObjectUtil; import com.xxl.job.core.biz.model.ReturnT; import com.xxl.job.core.handler.IJobHandler; @@ -41,6 +42,7 @@ public class ExpungeImTaskJob extends IJobHandler { public int expunge(Param nullableParam) { Param param = nullableParam == null ? new Param() : nullableParam; Date until = DateTime.now().minusDays(param.daysAgo).toDate(); + log.info("going to delete until={}", DateFormatUtil.toReadableString(until)); int count = messageTaskMapper.expunge(until); log.info("deleted count={}", count); return count;