1.调整删除历史数据代码
x_z
3 years ago
parent
353295da1c
commit
ff28e87abd
@ -0,0 +1,96 @@
|
|||||||
|
package com.glxp.sale.admin.thread;
|
||||||
|
|
||||||
|
import com.glxp.sale.admin.dao.info.ScheduledDao;
|
||||||
|
import com.glxp.sale.admin.entity.info.ScheduledEntity;
|
||||||
|
import com.glxp.sale.admin.req.udid.ScheduledRequest;
|
||||||
|
import com.glxp.sale.admin.service.basic.impl.BasicDownloadServiceImpl;
|
||||||
|
import com.glxp.sale.admin.service.basic.impl.BasicExportServiceImpl;
|
||||||
|
|
||||||
|
import com.glxp.sale.admin.service.thrsys.impl.*;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
||||||
|
import org.springframework.scheduling.annotation.SchedulingConfigurer;
|
||||||
|
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
|
||||||
|
import org.springframework.scheduling.support.CronTrigger;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
|
import javax.annotation.Resource;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 删除数据
|
||||||
|
*/
|
||||||
|
@Slf4j
|
||||||
|
@Component
|
||||||
|
@EnableScheduling
|
||||||
|
public class CleanDataTask implements SchedulingConfigurer {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private ScheduledDao scheduledDao;
|
||||||
|
@Resource
|
||||||
|
private BasicExportServiceImpl basicExportServiceImpl;
|
||||||
|
@Resource
|
||||||
|
private BasicDownloadServiceImpl basicDownloadServiceImpl;
|
||||||
|
@Resource
|
||||||
|
private ThrCorpExportLogServiceImpl thrCorpExportLogServiceImpl;
|
||||||
|
@Resource
|
||||||
|
private ThrCorpImportDetailServiceImpl thrCorpImportDetailServiceImpl;
|
||||||
|
@Resource
|
||||||
|
private ThrCorpImportLogServiceImpl thrCorpImportLogServiceImpl;
|
||||||
|
@Resource
|
||||||
|
private ThrImportLogServiceImpl thrImportLogServiceImpl;
|
||||||
|
@Resource
|
||||||
|
private ThrOrderDetailServiceImpl thrOrderDetailServiceImpl;
|
||||||
|
@Resource
|
||||||
|
private ThrOrderExportLogServiceImpl thrOrderExportLogServiceImpl;
|
||||||
|
@Resource
|
||||||
|
private ThrOrderImportDetailServiceImpl thrOrderImportDetailServiceImpl;
|
||||||
|
@Resource
|
||||||
|
private ThrOrderImportLogServiceImpl thrOrderImportLogServiceImpl;
|
||||||
|
@Resource
|
||||||
|
private ThrProductsImportLogServiceImpl thrProductsImportLogServiceImpl;
|
||||||
|
@Resource
|
||||||
|
private ThrProductsExportLogServiceImpl thrProductsExportLogServiceImpl;
|
||||||
|
@Resource
|
||||||
|
private ThrProductsImportDetailServiceImpl thrProductsImportDetailServiceImpl;
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
|
||||||
|
taskRegistrar.addTriggerTask(() -> process(),
|
||||||
|
triggerContext -> {
|
||||||
|
ScheduledRequest scheduledRequest = new ScheduledRequest();
|
||||||
|
scheduledRequest.setCronName("ScheduledDeletion");
|
||||||
|
ScheduledEntity scheduledEntity = scheduledDao.findScheduled(scheduledRequest);
|
||||||
|
String cron = scheduledEntity.getCron();
|
||||||
|
if (cron.isEmpty()) {
|
||||||
|
log.error("cron is null");
|
||||||
|
}
|
||||||
|
return new CronTrigger(cron).nextExecutionTime(triggerContext);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
private void process() {
|
||||||
|
log.info("开始清理 30 天前的历史数据");
|
||||||
|
//删除同步任务
|
||||||
|
log.info("开始删除同步任务历史记录");
|
||||||
|
basicExportServiceImpl.deleteByTime();
|
||||||
|
//删除下载记录
|
||||||
|
log.info("开始删除下载记录");
|
||||||
|
basicDownloadServiceImpl.deleteByTime();
|
||||||
|
//删除第三方数据
|
||||||
|
log.info("开始删除第三方数据");
|
||||||
|
thrCorpExportLogServiceImpl.deleteByTime();
|
||||||
|
thrCorpImportDetailServiceImpl.deleteByTime();
|
||||||
|
thrCorpImportLogServiceImpl.deleteByTime();
|
||||||
|
thrImportLogServiceImpl.deleteByTime();
|
||||||
|
thrOrderDetailServiceImpl.deleteByTime();
|
||||||
|
thrOrderExportLogServiceImpl.deleteByTime();
|
||||||
|
thrOrderImportDetailServiceImpl.deleteByTime();
|
||||||
|
thrOrderImportLogServiceImpl.deleteByTime();
|
||||||
|
thrProductsImportLogServiceImpl.deleteByTime();
|
||||||
|
thrProductsExportLogServiceImpl.deleteByTime();
|
||||||
|
thrProductsImportDetailServiceImpl.deleteByTime();
|
||||||
|
log.info("历史数据清理完成");
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
@ -1,95 +0,0 @@
|
|||||||
package com.glxp.sale.admin.thread;
|
|
||||||
|
|
||||||
import com.glxp.sale.admin.dao.info.ScheduledDao;
|
|
||||||
import com.glxp.sale.admin.entity.info.ScheduledEntity;
|
|
||||||
import com.glxp.sale.admin.req.udid.ScheduledRequest;
|
|
||||||
import com.glxp.sale.admin.service.basic.impl.BasicDownloadServiceImpl;
|
|
||||||
import com.glxp.sale.admin.service.basic.impl.BasicExportServiceImpl;
|
|
||||||
|
|
||||||
import com.glxp.sale.admin.service.thrsys.impl.*;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.springframework.scheduling.annotation.EnableScheduling;
|
|
||||||
import org.springframework.scheduling.annotation.SchedulingConfigurer;
|
|
||||||
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
|
|
||||||
import org.springframework.scheduling.support.CronTrigger;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
|
|
||||||
import javax.annotation.Resource;
|
|
||||||
;
|
|
||||||
/**
|
|
||||||
* 删除数据
|
|
||||||
*/
|
|
||||||
@Slf4j
|
|
||||||
@Component
|
|
||||||
@EnableScheduling
|
|
||||||
public class SupplementOrderTask2 implements SchedulingConfigurer {
|
|
||||||
@Resource
|
|
||||||
ScheduledDao scheduledDao;
|
|
||||||
@Resource
|
|
||||||
BasicExportServiceImpl basicExportServiceImpl;
|
|
||||||
@Resource
|
|
||||||
BasicDownloadServiceImpl basicDownloadServiceImpl;
|
|
||||||
@Resource
|
|
||||||
ThrCorpExportLogServiceImpl thrCorpExportLogServiceImpl;
|
|
||||||
@Resource
|
|
||||||
ThrCorpImportDetailServiceImpl thrCorpImportDetailServiceImpl;
|
|
||||||
@Resource
|
|
||||||
ThrCorpImportLogServiceImpl thrCorpImportLogServiceImpl;
|
|
||||||
@Resource
|
|
||||||
ThrImportLogServiceImpl thrImportLogServiceImpl;
|
|
||||||
@Resource
|
|
||||||
ThrOrderDetailServiceImpl thrOrderDetailServiceImpl;
|
|
||||||
@Resource
|
|
||||||
ThrOrderExportLogServiceImpl thrOrderExportLogServiceImpl;
|
|
||||||
@Resource
|
|
||||||
ThrOrderImportDetailServiceImpl thrOrderImportDetailServiceImpl;
|
|
||||||
@Resource
|
|
||||||
ThrOrderImportLogServiceImpl thrOrderImportLogServiceImpl;
|
|
||||||
@Resource
|
|
||||||
ThrProductsImportLogServiceImpl thrProductsImportLogServiceImpl;
|
|
||||||
@Resource
|
|
||||||
ThrProductsExportLogServiceImpl thrProductsExportLogServiceImpl;
|
|
||||||
@Resource
|
|
||||||
ThrProductsImportDetailServiceImpl thrProductsImportDetailServiceImpl;
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
|
|
||||||
taskRegistrar.addTriggerTask(() -> process(),
|
|
||||||
triggerContext -> {
|
|
||||||
ScheduledRequest scheduledRequest = new ScheduledRequest();
|
|
||||||
scheduledRequest.setCronName("ScheduledDeletion");
|
|
||||||
ScheduledEntity scheduledEntity = scheduledDao.findScheduled(scheduledRequest);
|
|
||||||
String cron = scheduledEntity.getCron();
|
|
||||||
if (cron.isEmpty()) {
|
|
||||||
log.error("cron is null");
|
|
||||||
}
|
|
||||||
return new CronTrigger(cron).nextExecutionTime(triggerContext);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
private void process() {
|
|
||||||
log.info("开始删除");
|
|
||||||
//删除同步任务
|
|
||||||
boolean b = basicExportServiceImpl.deleteByTime();
|
|
||||||
//删除下载记录
|
|
||||||
boolean b1 = basicDownloadServiceImpl.deleteByTime();
|
|
||||||
//删除第三方数据
|
|
||||||
boolean b2 = thrCorpExportLogServiceImpl.deleteByTime();
|
|
||||||
boolean b3 = thrCorpImportDetailServiceImpl.deleteByTime();
|
|
||||||
boolean b4 = thrCorpImportLogServiceImpl.deleteByTime();
|
|
||||||
boolean b5 = thrImportLogServiceImpl.deleteByTime();
|
|
||||||
boolean b6 = thrOrderDetailServiceImpl.deleteByTime();
|
|
||||||
boolean b7 = thrOrderExportLogServiceImpl.deleteByTime();
|
|
||||||
boolean b8 = thrOrderImportDetailServiceImpl.deleteByTime();
|
|
||||||
boolean b12 = thrOrderImportLogServiceImpl.deleteByTime();
|
|
||||||
boolean b9 = thrProductsImportLogServiceImpl.deleteByTime();
|
|
||||||
boolean b10 = thrProductsExportLogServiceImpl.deleteByTime();
|
|
||||||
boolean b11 = thrProductsImportDetailServiceImpl.deleteByTime();
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
log.info("删除结束");
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
Loading…
Reference in New Issue