From 448594231e3389ebf580e2c629b4ebcadf9bb314 Mon Sep 17 00:00:00 2001
From: wangwei <1610949092@qq.com>
Date: Wed, 14 Dec 2022 10:23:07 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E5=88=A0=E9=99=A4=E5=90=8C?=
 =?UTF-8?q?=E6=AD=A5=E4=BB=BB=E5=8A=A1=E3=80=81=E4=B8=8B=E8=BD=BD=E8=AE=B0?=
 =?UTF-8?q?=E5=BD=95=E5=92=8C=E7=AC=AC=E4=B8=89=E6=96=B9=E6=95=B0=E6=8D=AE?=
 =?UTF-8?q?=E7=9A=8430=E5=A4=A9=E4=B9=8B=E5=89=8D=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../admin/thread/SupplementOrderTask2.java    | 95 +++++++++++++++++++
 1 file changed, 95 insertions(+)
 create mode 100644 api-admin/src/main/java/com/glxp/sale/admin/thread/SupplementOrderTask2.java

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