-2

kimi

2020-03-17 8f4e6484f0b27f471e81c3667142cb1324f4be4e

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

@@ -1,11 +1,45 @@
package com.highdatas.srs.task;



import com.baomidou.mybatisplus.mapper.EntityWrapper;

import com.highdatas.srs.entity.Scheme;

import com.highdatas.srs.entity.SchemeDetail;

import com.highdatas.srs.service.ISchemeDetailService;

import com.highdatas.srs.service.ISchemeService;

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

import org.springframework.scheduling.annotation.EnableScheduling;

import org.springframework.scheduling.annotation.Scheduled;



import java.util.Date;

import java.util.HashSet;

import java.util.List;



/**

 * @author kimi

 * @description

 * @date 2020-02-12 10:40

 */





@EnableScheduling

public class DelayTimeTask {

}

    @Autowired

    ISchemeService schemeService;

    @Autowired

    ISchemeDetailService schemeDetailService;



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

    private void delayTask(){

        Date date = new Date();

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

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

        for (SchemeDetail detail : schemeDetailList) {

            parentIdSet.add(detail.getParentId());

            detail.setDelay(true);

            detail.updateById();

        }

        //项目中某个节点发生延期则项目延期  后期根据业务修改

        List<Scheme> schemes = schemeService.selectBatchIds(parentIdSet);

        for (Scheme scheme : schemes) {

            scheme.setStatus("delay").updateById();

        }

    }

 }