对实施日期进行预警.更新对条款的预警,加入使用车型和责任工程师

This commit is contained in:
zhaokaiyao@91isoft.com
2021-08-31 14:04:28 +08:00
parent bb378b56a7
commit 02dc65167e
8 changed files with 61 additions and 19 deletions
@@ -7,6 +7,7 @@ import com.adc.da.scheduled.entity.DataDTO;
import com.adc.da.scheduled.entity.WarningEO; import com.adc.da.scheduled.entity.WarningEO;
import com.adc.da.slrs.sarStandAttrInfo.dao.SarStandAttrInfoDao; import com.adc.da.slrs.sarStandAttrInfo.dao.SarStandAttrInfoDao;
import com.adc.da.slrs.sarStandAttrInfo.entity.SarStandAttrInfo; import com.adc.da.slrs.sarStandAttrInfo.entity.SarStandAttrInfo;
import com.adc.da.slrs.sarStandWarning.entity.EarlyWarningEO;
import com.adc.da.slrs.sarStandardsInfo.dao.SarStandardsInfoDao; import com.adc.da.slrs.sarStandardsInfo.dao.SarStandardsInfoDao;
import com.adc.da.slrs.sarStandardsInfo.entity.SarStandardsInfo; import com.adc.da.slrs.sarStandardsInfo.entity.SarStandardsInfo;
import com.adc.da.util.UUIDUtils; import com.adc.da.util.UUIDUtils;
@@ -54,8 +55,8 @@ public class ScheduledJob {
@Scheduled(cron = "0 0 0 * * ?") //每天的凌晨0点执行 // @Scheduled(cron = "0 0 0 * * ?") //每天的凌晨0点执行
// @Scheduled(cron="*/5 * * * * ?") @Scheduled(cron="*/5 * * * * ?")
@Async @Async
public void WarningSchedulingTasks() { public void WarningSchedulingTasks() {
@@ -76,6 +77,14 @@ public class ScheduledJob {
1:新车条款预警 1:新车条款预警
2:在产车条款预警 2:在产车条款预警
*/ */
//删除不在预警范围的标准
QueryWrapper<EarlyWarningEO> earlyWarningEOQW = new QueryWrapper<>();
earlyWarningEOQW.lt("PUT_TIME",LocalDate.now());
int remove = sarStandardWarningDao.delete(earlyWarningEOQW);
System.out.println(remove);
System.out.println("开始执行预警!!!"); System.out.println("开始执行预警!!!");
DataDTO term = new DataDTO(); //预警期限(当前日期至3个月后) DataDTO term = new DataDTO(); //预警期限(当前日期至3个月后)
@@ -98,6 +107,7 @@ public class ScheduledJob {
.setPower("1") .setPower("1")
.setMark("2") .setMark("2")
.setPutTime(warningEO.getZCCSSRQ()); .setPutTime(warningEO.getZCCSSRQ());
} }
warningList.addAll(itemForZCCSSRQ); warningList.addAll(itemForZCCSSRQ);
@@ -109,6 +119,8 @@ public class ScheduledJob {
.setMark("3") .setMark("3")
.setPutTime(warningEO.getXCXSSRQ()) .setPutTime(warningEO.getXCXSSRQ())
.setStandCode(warningEO.getStandSort()+" "+ warningEO.getStandNum()+"-"+ warningEO.getStandYear()); .setStandCode(warningEO.getStandSort()+" "+ warningEO.getStandNum()+"-"+ warningEO.getStandYear());
} }
warningList.addAll(standInfoXCXSSRQ); warningList.addAll(standInfoXCXSSRQ);
@@ -143,8 +155,8 @@ public class ScheduledJob {
// @Scheduled(cron = "0 0 0 * * ?") //每天的凌晨0点执行 @Scheduled(cron = "0 0 0 * * ?") //每天的凌晨0点执行
@Scheduled(cron="*/5 * * * * ?") // @Scheduled(cron="*/5 * * * * ?")
@Async @Async
public void TextStatusSchedulingTasks() { public void TextStatusSchedulingTasks() {
QueryWrapper<SarStandardsInfo> wrapper = new QueryWrapper<>(); QueryWrapper<SarStandardsInfo> wrapper = new QueryWrapper<>();
@@ -1,6 +1,8 @@
package com.adc.da.scheduled.dao; package com.adc.da.scheduled.dao;
import com.adc.da.scheduled.entity.WarningEO; import com.adc.da.scheduled.entity.WarningEO;
import com.adc.da.slrs.sarStandWarning.entity.EarlyWarningEO;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
@@ -9,7 +11,7 @@ import org.springframework.stereotype.Repository;
import java.util.LinkedList; import java.util.LinkedList;
@Repository @Repository
public interface SarStandardWarningDao extends IService<WarningEO> { public interface SarStandardWarningDao extends BaseMapper<EarlyWarningEO> {
public int ignoreInsert(@Param(value = "warningEOS") LinkedList<WarningEO> warningEOS); public int ignoreInsert(@Param(value = "warningEOS") LinkedList<WarningEO> warningEOS);
} }
@@ -1,10 +1,16 @@
package com.adc.da.scheduled.entity; package com.adc.da.scheduled.entity;
import com.alibaba.druid.sql.visitor.functions.Char;
import com.sun.org.apache.bcel.internal.generic.NEW;
import lombok.Data; import lombok.Data;
import lombok.experimental.Accessors; import lombok.experimental.Accessors;
import org.apache.poi.ss.formula.functions.T;
import org.springframework.format.annotation.DateTimeFormat; import org.springframework.format.annotation.DateTimeFormat;
import java.text.SimpleDateFormat;
import java.time.LocalDate; import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.Date;
@Data @Data
@Accessors(chain = true) @Accessors(chain = true)
@@ -30,4 +36,19 @@ public class DataDTO {
this.endDate=endDate; this.endDate=endDate;
} }
//
// public boolean isTerm(T date){
//
// if (date.getClass().equals(Date.class)){
//
// }
//
//
// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");//线程不安全
//
// DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd");
// String dataStr= dtf.format(LocalDate.now());
// LocalDate localDateTime = LocalDate.parse(dataStr, dtf);
// return
// }
} }
@@ -22,6 +22,9 @@ public class WarningEO extends EarlyWarningEO {
@DateTimeFormat(pattern = "YYYY-MM-dd") @DateTimeFormat(pattern = "YYYY-MM-dd")
private Date ZCCSSRQ; private Date ZCCSSRQ;
@DateTimeFormat(pattern = "YYYY-MM-dd")
private Date SSRQ;
private String standNum; private String standNum;
private String standSort; private String standSort;
@@ -10,6 +10,7 @@ import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors; import lombok.experimental.Accessors;
import java.time.LocalDate;
import java.util.Date; import java.util.Date;
@Data @Data
@@ -108,9 +108,7 @@ public class EarlyWarningEOServiceImpl extends ServiceImpl<EarlyWarningEODao, Ea
return "更改成功"; return "更改成功";
} }
private IPage<EarlyWarningEO> getEarlyWarningEOIPage(int current,int pageSize, QueryWrapper<EarlyWarningEO> wrapper) { private IPage<EarlyWarningEO> getEarlyWarningEOIPage(int current,int pageSize, QueryWrapper<EarlyWarningEO> wrapper) {
DataDTO dataDTO = new DataDTO(); wrapper.eq("power",1);
wrapper.eq("power",1)
.between("PUT_TIME",dataDTO.getStartDate(),dataDTO.getEndDate());
Page<EarlyWarningEO> page = new Page<>(current, pageSize); Page<EarlyWarningEO> page = new Page<>(current, pageSize);
IPage<EarlyWarningEO> userIPage = earlyWarningEODao.selectPage(page, wrapper); IPage<EarlyWarningEO> userIPage = earlyWarningEODao.selectPage(page, wrapper);
System.out.println("总条数"+userIPage.getTotal()); System.out.println("总条数"+userIPage.getTotal());
@@ -11,6 +11,7 @@
<result column="STAND_YEAR" property="standYear"/> <result column="STAND_YEAR" property="standYear"/>
<result column="XCXSSRQ" property="XCXSSRQ"/> <result column="XCXSSRQ" property="XCXSSRQ"/>
<result column="ZCCSSRQ" property="ZCCSSRQ"/> <result column="ZCCSSRQ" property="ZCCSSRQ"/>
<result column="SSRQ" property="SSRQ"/>
<result column="CLLX" property="applyType" /> <result column="CLLX" property="applyType" />
<result column="STAND_TYPE" property="standType" /> <result column="STAND_TYPE" property="standType" />
<result column="ZRGCS" property="dutyEngineer" /> <result column="ZRGCS" property="dutyEngineer" />
@@ -27,6 +28,7 @@
info.STAND_TYPE, info.STAND_TYPE,
attrInfo.CLLX, attrInfo.CLLX,
attrInfo.ZRGCS, attrInfo.ZRGCS,
attrInfo.SSRQ,
attrInfo.${str} attrInfo.${str}
FROM FROM
sar_standards_info AS info sar_standards_info AS info
@@ -35,9 +37,11 @@
1=1 1=1
<if test="date!=null"> <if test="date!=null">
and and
attrInfo.SSRQ
BETWEEN #{date.startDate} and #{date.endDate}
or
attrInfo.${str} attrInfo.${str}
BETWEEN DATE_FORMAT( #{date.startDate},'%Y-%m-%d %H:%i:%s') BETWEEN #{date.startDate} and #{date.endDate}
and DATE_FORMAT( #{date.endDate},'%Y-%m-%d %H:%i:%s')
</if> </if>
</where> </where>
@@ -20,22 +20,23 @@
<select id="selectWithinTerm" resultMap="resultMap" parameterType="com.adc.da.scheduled.entity.DataDTO"> <select id="selectWithinTerm" resultMap="resultMap" parameterType="com.adc.da.scheduled.entity.DataDTO">
SELECT SELECT
items.ID, items.ID,
STAND_ID, items.ITEMS_NUM,
ITEMS_NUM, items.ITEMS_NAME,
ITEMS_NAME, items.TERMS_CONDITIONS,
TERMS_CONDITIONS, items.DUTY_ENGINEER,
DUTY_ENGINEER, items.STAND_ID,
APPLY_ARCTIC,
info.STAND_TYPE, info.STAND_TYPE,
info.STAND_NUMBER, info.STAND_NUMBER,
attrInfo.CLLX,
${str} attrInfo.ZRGCS,
items.${str}
FROM FROM
sar_stand_items AS items sar_stand_items AS items
JOIN sar_standards_info AS info ON items.STAND_ID=info.ID JOIN sar_standards_info AS info ON items.STAND_ID=info.ID
JOIN sar_stand_attr_info AS attrInfo ON info.id = attrinfo.stand_id
WHERE WHERE
${str} BETWEEN #{date.startDate} and #{date.endDate} items.${str} BETWEEN #{date.startDate} and #{date.endDate}
</select> </select>
</mapper> </mapper>