From eba71773f2e62dbe1975260da38b29254ab52cc3 Mon Sep 17 00:00:00 2001
From: bai <1643359946@qq.com>
Date: Tue, 6 Jun 2023 00:00:24 +0800
Subject: [PATCH] =?UTF-8?q?2023=E5=B9=B46=E6=9C=886=E6=97=A5=20=E6=B7=BB?=
 =?UTF-8?q?=E5=8A=A0=E5=B0=86=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1=E4=B8=B2?=
 =?UTF-8?q?=E8=B5=B7=E6=9D=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../SyncTFwdtBkjxtkpj.java                    | 31 ++++++++++++++++---
 1 file changed, 26 insertions(+), 5 deletions(-)

diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncTFwdtBkjxtkpj.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncTFwdtBkjxtkpj.java
index 16e558b5..223e9e2c 100644
--- a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncTFwdtBkjxtkpj.java
+++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncTFwdtBkjxtkpj.java
@@ -4,7 +4,6 @@ import cn.hutool.core.bean.BeanUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.compress.utils.Lists;
-import org.apache.commons.lang.StringUtils;
 import org.jeecg.common.util.DateUtils;
 import org.jeecg.modules.kc.grab.SynchronizationService.base.BaseSync;
 import org.jeecg.modules.kc.grab.exports.entity.TFwdtBkjxtkpj;
@@ -12,16 +11,19 @@ import org.jeecg.modules.kc.grab.exports.service.ITFwdtBkjxtkpjService;
 import org.jeecg.modules.kc.grab.imports.entity.Xxhbbkjxtkpj;
 import org.jeecg.modules.kc.grab.imports.entity.Xxhbsynclog;
 import org.jeecg.modules.kc.grab.imports.service.IXxhbbkjxtkpjService;
-import org.jeecg.modules.kc.ktgl.entity.KcKetangbiao;
 import org.jeecg.modules.kc.ktgl.service.IKcKetangbiaoService;
-import org.jeecg.modules.kc.qa.entity.KcEvaluation;
-import org.jeecg.modules.kc.qa.entity.KcEvaluations;
 import org.jeecg.modules.kc.qa.service.IKcEvaluationService;
 import org.jeecg.modules.kc.qa.service.IKcEvaluationsService;
+import org.jeecg.modules.quartz.entity.QuartzJob;
+import org.jeecg.modules.quartz.mapper.QuartzJobMapper;
+import org.jeecg.modules.quartz.service.IQuartzJobService;
 import org.quartz.JobExecutionContext;
 import org.springframework.beans.factory.annotation.Autowired;
 
-import java.util.*;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
 
 /**
  * 服务大厅-本科教学服务评价
@@ -44,6 +46,9 @@ public class SyncTFwdtBkjxtkpj extends BaseSync {
     @Autowired
     private IKcKetangbiaoService kcKetangbiaoService;
 
+    @Autowired
+    private IQuartzJobService quartzJobService;
+
     /**
      * 若参数变量名修改 QuartzJobController中也需对应修改
      */
@@ -61,6 +66,8 @@ public class SyncTFwdtBkjxtkpj extends BaseSync {
      * @param param
      */
     public void run(Map<String, Object> param){
+
+
         //查询数据
         Date date = new Date();//获取当前时间
         Calendar calendar = Calendar.getInstance();
@@ -360,6 +367,20 @@ public class SyncTFwdtBkjxtkpj extends BaseSync {
 //
 //        }
 
+        //执行清洗
+        QueryWrapper<QuartzJob> jobQw = new QueryWrapper<>();
+        jobQw.eq("job_class_name","org.jeecg.modules.kc.grab.SynchronizationService.SyncZwdtEvaluation");
+        jobQw.last("limit 1");
+        QuartzJob quartzJob = quartzJobService.getOne(jobQw);
+        try {
+            if(quartzJob != null){
+                quartzJobService.execute(quartzJob);
+            }
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+
+
         Xxhbsynclog xxhbsynclog = new Xxhbsynclog();
         xxhbsynclog.setSyncRowNum(String.valueOf(outDataList.size()));
         saveLog(xxhbsynclog,Xxhbbkjxtkpj.class);