diff --git a/share-api/src/main/java/com/xjy/ai/api/ApiApplication.java b/share-api/src/main/java/com/xjy/ai/api/ApiApplication.java index 8a7b725..a372a39 100644 --- a/share-api/src/main/java/com/xjy/ai/api/ApiApplication.java +++ b/share-api/src/main/java/com/xjy/ai/api/ApiApplication.java @@ -3,9 +3,11 @@ package com.xjy.ai.api; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.context.annotation.ComponentScan; +import org.springframework.scheduling.annotation.EnableScheduling; @SpringBootApplication @ComponentScan("com.xjy.*") +@EnableScheduling public class ApiApplication { public static void main(String[] args) { diff --git a/share-common/src/main/java/com/xjy/ai/common/enums/StatusEnum.java b/share-common/src/main/java/com/xjy/ai/common/enums/StatusEnum.java index 5e1da04..3bfdc52 100644 --- a/share-common/src/main/java/com/xjy/ai/common/enums/StatusEnum.java +++ b/share-common/src/main/java/com/xjy/ai/common/enums/StatusEnum.java @@ -7,7 +7,8 @@ public enum StatusEnum { REJECT("3", "审核未通过"), FINISH("4", "完成"), DELAY("5", "延期"), - OTHER("6", "其他"); + OTHER("6", "其他"), + NOT_PASS("7", "验收未通过"); private String key; private String value; diff --git a/share-model/src/main/java/com/xjy/ai/model/task/RequirTask.java b/share-model/src/main/java/com/xjy/ai/model/task/RequirTask.java new file mode 100644 index 0000000..6e2cea2 --- /dev/null +++ b/share-model/src/main/java/com/xjy/ai/model/task/RequirTask.java @@ -0,0 +1,40 @@ +package com.xjy.ai.model.task; + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.xjy.ai.common.enums.StatusEnum; +import com.xjy.ai.model.dao.requirement.entity.Requirement; +import com.xjy.ai.model.service.requirement.RequirementService; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; +import org.springframework.util.CollectionUtils; + +import java.util.Date; +import java.util.List; + +@Component +public class RequirTask { + + Logger logger = LoggerFactory.getLogger(this.getClass()); + + @Autowired + private RequirementService requirementService; + @Scheduled(cron = "0 0/3 * * * *") + public void work() { + QueryWrapper wrapper = new QueryWrapper<>(); + wrapper.eq("status", StatusEnum.ING.getKey()); + List list = requirementService.list(wrapper); + if(!CollectionUtils.isEmpty(list)){ + for(Requirement requirement : list){ + long diff = new Date().getTime() - requirement.getEndTime().getTime(); + if(diff > 0){ + requirement.setStatus(StatusEnum.DELAY.getKey()); + requirementService.updateByPrimaryKey(requirement); + logger.info("update status:{}",requirement.getId()); + } + } + } + } +} diff --git a/share-model/src/main/resources/mapper/sys/DicItemMapper.xml b/share-model/src/main/resources/mapper/sys/DicItemMapper.xml index 9475ab1..ee0b978 100644 --- a/share-model/src/main/resources/mapper/sys/DicItemMapper.xml +++ b/share-model/src/main/resources/mapper/sys/DicItemMapper.xml @@ -281,6 +281,7 @@ dic_item where dic_type_code = #{dicTypeCode,jdbcType=VARCHAR} + order by dic_item_order