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:21:49 +08:00
parent e64edeb0c0
commit eccef94911
2 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
im-center-server/src/main/java/cn/axzo/im/controller/PrivateController.java
View File

@ -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);
}
}

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

@ -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