diff --git a/api-admin/src/main/java/com/glxp/sale/admin/thread/SupplementOrderTask2.java b/api-admin/src/main/java/com/glxp/sale/admin/thread/SupplementOrderTask2.java new file mode 100644 index 0000000..6ff3b7c --- /dev/null +++ b/api-admin/src/main/java/com/glxp/sale/admin/thread/SupplementOrderTask2.java @@ -0,0 +1,95 @@ +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("supplementOrderTask2"); + 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("删除结束"); + } + + +}