diff --git a/adc-da-slrs/src/main/java/com/adc/da/scheduled/ImplementScheduledJob.java b/adc-da-slrs/src/main/java/com/adc/da/scheduled/ImplementScheduledJob.java new file mode 100644 index 00000000..a42afeaf --- /dev/null +++ b/adc-da-slrs/src/main/java/com/adc/da/scheduled/ImplementScheduledJob.java @@ -0,0 +1,32 @@ +package com.adc.da.scheduled; + +import com.adc.da.slrs.sarStandardsInfo.dao.SarStandardsInfoDao; +import com.adc.da.slrs.sarStandardsInfo.entity.SarStandardsInfo; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.scheduling.annotation.Async; +import org.springframework.scheduling.annotation.EnableScheduling; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +@EnableScheduling +@Component +@Slf4j +public class ImplementScheduledJob { + + @Autowired + private SarStandardsInfoDao sarStandardsInfoDao; + + + @Scheduled(cron = "0 0 0 * * ?") //每天的凌晨0点执行 +// @Scheduled(cron="*/5 * * * * ?") + @Async + public void schedulingTasks() { + QueryWrapper wrapper = new QueryWrapper<>(); + + + } + + +} diff --git a/adc-da-slrs/src/main/java/com/adc/da/scheduled/ScheduledJob.java b/adc-da-slrs/src/main/java/com/adc/da/scheduled/WarningScheduledJob.java similarity index 96% rename from adc-da-slrs/src/main/java/com/adc/da/scheduled/ScheduledJob.java rename to adc-da-slrs/src/main/java/com/adc/da/scheduled/WarningScheduledJob.java index c984a930..d46769ca 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/scheduled/ScheduledJob.java +++ b/adc-da-slrs/src/main/java/com/adc/da/scheduled/WarningScheduledJob.java @@ -21,7 +21,7 @@ import java.util.List; @EnableScheduling @Component @Slf4j -public class ScheduledJob { +public class WarningScheduledJob { /** * 根据配置文件设置是否开启定时器 @@ -84,7 +84,7 @@ public class ScheduledJob { LinkedList warningList = new LinkedList<>();//需预警的标准和条款列表集合 //分解单(条款) 新车型 mark=1 - List itemForXCXSSRQ = sarStandardItemDao.select(term, "XCXSSRQ"); + List itemForXCXSSRQ = sarStandardItemDao.selectWithinTerm(term, "XCXSSRQ"); for (WarningEO warningEO : itemForXCXSSRQ) { warningEO.setId(UUIDUtils.randomUUID20()) .setPower("1") @@ -94,7 +94,7 @@ public class ScheduledJob { warningList.addAll(itemForXCXSSRQ); //分解单(条款) 在产车型 mark=2 - List itemForZCCSSRQ = sarStandardItemDao.select(term, "ZCCSSRQ"); + List itemForZCCSSRQ = sarStandardItemDao.selectWithinTerm(term, "ZCCSSRQ"); for (WarningEO warningEO : itemForZCCSSRQ) { warningEO.setId(UUIDUtils.randomUUID20()) .setPower("1") @@ -104,7 +104,7 @@ public class ScheduledJob { warningList.addAll(itemForZCCSSRQ); //标准 新车型 预警 mark=3 - List standInfoXCXSSRQ = sarStandardInfoDao.select(term, "XCXSSRQ"); + List standInfoXCXSSRQ = sarStandardInfoDao.selectWithinTerm(term, "XCXSSRQ"); for (WarningEO warningEO : standInfoXCXSSRQ) { warningEO.setId(UUIDUtils.randomUUID20()) .setPower("1") @@ -115,7 +115,7 @@ public class ScheduledJob { //标准 在产车型 mark=4 - List standInfoZCCSSRQ = sarStandardInfoDao.select(term, "ZCCSSRQ"); + List standInfoZCCSSRQ = sarStandardInfoDao.selectWithinTerm(term, "ZCCSSRQ"); for (WarningEO warningEO : standInfoZCCSSRQ) { warningEO.setId(UUIDUtils.randomUUID20()) .setPower("1") diff --git a/adc-da-slrs/src/main/java/com/adc/da/scheduled/dao/SarStandardInfoDao.java b/adc-da-slrs/src/main/java/com/adc/da/scheduled/dao/SarStandardInfoDao.java index f2679cbc..9203db20 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/scheduled/dao/SarStandardInfoDao.java +++ b/adc-da-slrs/src/main/java/com/adc/da/scheduled/dao/SarStandardInfoDao.java @@ -12,6 +12,6 @@ import java.util.List; @Repository public interface SarStandardInfoDao{ - public List select(DataDTO date, String str); + public List selectWithinTerm(DataDTO date, String str); } diff --git a/adc-da-slrs/src/main/java/com/adc/da/scheduled/dao/SarStandardItemDao.java b/adc-da-slrs/src/main/java/com/adc/da/scheduled/dao/SarStandardItemDao.java index 401c9fa4..b21f0af8 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/scheduled/dao/SarStandardItemDao.java +++ b/adc-da-slrs/src/main/java/com/adc/da/scheduled/dao/SarStandardItemDao.java @@ -12,6 +12,6 @@ import java.util.List; @Repository public interface SarStandardItemDao extends BaseMapper{ - public List select(DataDTO date, String str); + public List selectWithinTerm(DataDTO date, String str); } diff --git a/adc-da-slrs/src/main/resources/mybatis/mapper/sarStandWarning/SarStandardInfo.xml b/adc-da-slrs/src/main/resources/mybatis/mapper/sarStandWarning/SarStandardInfo.xml index 518aa911..53e0582a 100644 --- a/adc-da-slrs/src/main/resources/mybatis/mapper/sarStandWarning/SarStandardInfo.xml +++ b/adc-da-slrs/src/main/resources/mybatis/mapper/sarStandWarning/SarStandardInfo.xml @@ -15,7 +15,7 @@ - SELECT info.ID, info.STAND_NUMBER, diff --git a/adc-da-slrs/src/main/resources/mybatis/mapper/sarStandWarning/SarStandardItem.xml b/adc-da-slrs/src/main/resources/mybatis/mapper/sarStandWarning/SarStandardItem.xml index 01a5167a..d05e821b 100644 --- a/adc-da-slrs/src/main/resources/mybatis/mapper/sarStandWarning/SarStandardItem.xml +++ b/adc-da-slrs/src/main/resources/mybatis/mapper/sarStandWarning/SarStandardItem.xml @@ -17,7 +17,7 @@ - SELECT items.ID, STAND_ID,