提交

kimi

2020-11-27 75c32d6d697a550400d0b4eec95b8570d83b726f

 src/main/java/com/highdatas/srs/task/DelayTimeTask.java

@@ -5,9 +5,10 @@
import com.highdatas.srs.entity.SchemeDetail;

import com.highdatas.srs.service.ISchemeDetailService;

import com.highdatas.srs.service.ISchemeService;

import lombok.extern.slf4j.Slf4j;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.scheduling.annotation.EnableScheduling;

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;



import java.util.Date;

import java.util.HashSet;

@@ -19,17 +20,19 @@
 * @date 2020-02-12 10:40

 */



@EnableScheduling

@Component

@Slf4j

public class DelayTimeTask {

    @Autowired

    ISchemeService schemeService;

    @Autowired

    ISchemeDetailService schemeDetailService;



    @Scheduled(cron = "0 0 0 1/1 * ?")

    @Scheduled(cron = "0 0 1 1/1 * ?")

    private void delayTask(){

        log.info("start 定时任务");

        Date date = new Date();

        List<SchemeDetail> schemeDetailList = schemeDetailService.selectList(new EntityWrapper<SchemeDetail>().lt("end_time", date).eq("edit", false));

        List<SchemeDetail> schemeDetailList = schemeDetailService.selectList(new EntityWrapper<SchemeDetail>().lt("end_time", date).eq("edit", false).eq("finish", false));

        HashSet<String> parentIdSet = new HashSet<>();

        for (SchemeDetail detail : schemeDetailList) {

            parentIdSet.add(detail.getParentId());