wangli/im-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

删除1周前无用的im task数据

Browse Source
This commit is contained in:
yanglin 2024-05-09 14:26:20 +08:00
parent 834f986196
commit cc8a0cdf27
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
im-center-server/src/main/java/cn/axzo/im/job/ExpungeImTaskJob.java
View File

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