定时删除同步任务、下载记录和第三方数据的30天之前数据

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("删除结束");
+    }
+
+
+}