From fae2fc8673d1a7efb71fd79a56802a7516181ce3 Mon Sep 17 00:00:00 2001
From: yangjun <1173114630@qq.com>
Date: Thu, 17 Oct 2024 19:57:05 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AE=9A=E6=97=B6=E5=8F=91?=
 =?UTF-8?q?=E5=B8=83=E4=BD=9C=E4=B8=9A=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../kc/grab/SynchronizationService/SyncZyCcjg.java | 14 +++++++++++++-
 .../modules/kc/zyInfo/service/IZyInfoService.java  |  1 +
 .../kc/zyInfo/service/impl/ZyInfoServiceImpl.java  | 14 ++++++++++++++
 3 files changed, 28 insertions(+), 1 deletion(-)

diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncZyCcjg.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncZyCcjg.java
index f8cba355..f3bd1529 100644
--- a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncZyCcjg.java
+++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncZyCcjg.java
@@ -3,6 +3,7 @@ package org.jeecg.modules.kc.grab.SynchronizationService;
 import lombok.extern.slf4j.Slf4j;
 import org.jeecg.modules.kc.grab.SynchronizationService.base.BaseSync;
 import org.jeecg.modules.kc.zyCcjg.service.IZyCcjgService;
+import org.jeecg.modules.kc.zyInfo.service.IZyInfoService;
 import org.quartz.JobExecutionContext;
 import org.springframework.beans.factory.annotation.Autowired;
 
@@ -17,6 +18,8 @@ public class SyncZyCcjg extends BaseSync {
     @Autowired
     private IZyCcjgService zyCcjgService;
 
+    @Autowired
+    private IZyInfoService zyInfoService;
 
     /**
      * 若参数变量名修改 QuartzJobController中也需对应修改
@@ -35,7 +38,16 @@ public class SyncZyCcjg extends BaseSync {
      * @param param
      */
     public void run(Map<String, Object> param){
-        zyCcjgService.getCcjg();
+        try {
+            zyCcjgService.getCcjg();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        try {
+            zyInfoService.updateInfoZyStatus();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
     }
 
     /**
diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/zyInfo/service/IZyInfoService.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/zyInfo/service/IZyInfoService.java
index 260e86a3..47dd6878 100644
--- a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/zyInfo/service/IZyInfoService.java
+++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/zyInfo/service/IZyInfoService.java
@@ -27,4 +27,5 @@ public interface IZyInfoService extends IService<ZyInfo> {
 
     List<ZyInfo> zyzb(String rwbh, String xqxn, String teano, String zyLeixing);
 
+    void updateInfoZyStatus();
 }
diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/zyInfo/service/impl/ZyInfoServiceImpl.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/zyInfo/service/impl/ZyInfoServiceImpl.java
index 89ce2ddd..96f44ec6 100644
--- a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/zyInfo/service/impl/ZyInfoServiceImpl.java
+++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/zyInfo/service/impl/ZyInfoServiceImpl.java
@@ -7,10 +7,12 @@ import org.jeecg.modules.kc.zyInfo.entity.ZyInfo;
 import org.jeecg.modules.kc.zyInfo.entity.ZyInfoSys;
 import org.jeecg.modules.kc.zyInfo.mapper.ZyInfoMapper;
 import org.jeecg.modules.kc.zyInfo.service.IZyInfoService;
+import org.jeecg.modules.tools.DateUtils;
 import org.springframework.stereotype.Service;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -47,4 +49,16 @@ public class ZyInfoServiceImpl extends ServiceImpl<ZyInfoMapper, ZyInfo> impleme
         return baseMapper.zyzb(rwbh,xqxn,teano,zyLeixing);
     }
 
+    @Override
+    public void updateInfoZyStatus() {
+        QueryWrapper<ZyInfo> zyInfoQueryWrapper = new QueryWrapper<>();
+        zyInfoQueryWrapper.le("start_time", DateUtils.format(new Date(),"yyyy-MM-dd HH:mm:ss"));
+        zyInfoQueryWrapper.eq("zy_status","0");
+        List<ZyInfo> list = baseMapper.selectList(zyInfoQueryWrapper);
+        for(ZyInfo par : list){
+            par.setZyStatus("1");
+            baseMapper.updateById(par);
+        }
+    }
+
 }