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 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 { List 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 impleme return baseMapper.zyzb(rwbh,xqxn,teano,zyLeixing); } + @Override + public void updateInfoZyStatus() { + QueryWrapper zyInfoQueryWrapper = new QueryWrapper<>(); + zyInfoQueryWrapper.le("start_time", DateUtils.format(new Date(),"yyyy-MM-dd HH:mm:ss")); + zyInfoQueryWrapper.eq("zy_status","0"); + List list = baseMapper.selectList(zyInfoQueryWrapper); + for(ZyInfo par : list){ + par.setZyStatus("1"); + baseMapper.updateById(par); + } + } + }