检查组装计划的定时任务

刘小明

2024-07-11 cbd83560cffd9e9d055108717e4f9dec0aa6b58f

检查组装计划的定时任务

 pms-parent/pms-web-product/src/main/java/com/dy/pmsProduct/PmsProductApplication.java

@@ -1,7 +1,5 @@
package com.dy.pmsProduct;

import com.dy.common.schedulerTask.SchedulerTaskSupport;
import com.dy.common.schedulerTask.Test;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@@ -16,12 +14,6 @@

    public static void main(String[] args) {
        SpringApplication.run(PmsProductApplication.class, args);
        try {
            SchedulerTaskSupport.addSecondlyJob("test", "testGroup", Test.class, null,
                    10, 1, -1) ;
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}

 pms-parent/pms-web-product/src/main/java/com/dy/pmsProduct/config/AppStartupRunner.java

New file
@@ -0,0 +1,18 @@
package com.dy.pmsProduct.config;

import com.dy.common.schedulerTask.SchedulerTaskSupport;
import com.dy.pmsProduct.taskPlan.AssemblyPlanTask;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

@Component
public class AppStartupRunner implements CommandLineRunner {

    @Override
    public void run(String... args) throws Exception {
//        SchedulerTaskSupport.addDailyJob("assemblyPlanTask", "taskPlan", AssemblyPlanTask.class,
//                null, 11, 2);
        SchedulerTaskSupport.addMinutelyJob("assemblyPlanTask", "taskPlan", AssemblyPlanTask.class,
                null, 20, 5,-1);
    }
}

 pms-parent/pms-web-product/src/main/java/com/dy/pmsProduct/taskPlan/AssemblyPlanTask.java

New file
@@ -0,0 +1,42 @@
package com.dy.pmsProduct.taskPlan;

import cn.hutool.core.date.DateUnit;
import cn.hutool.core.date.DateUtil;
import com.dy.common.schedulerTask.TaskJob;
import com.dy.common.springUtil.SpringContextUtil;
import com.dy.pmsGlobal.daoPr.PrAssemblyPlanMapper;
import com.dy.pmsGlobal.daoPr.PrDeviceMapper;
import com.dy.pmsGlobal.pojoPr.PrAssemblyPlan;
import com.dy.pmsGlobal.util.DeviceStatus;
import lombok.extern.slf4j.Slf4j;
import org.quartz.JobExecutionContext;
import org.springframework.stereotype.Component;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Slf4j
@Component
public class AssemblyPlanTask extends TaskJob {

    @Override
    public void execute(JobExecutionContext ctx) {
        log.info("开始执行 组装计划任务定时检查");
        PrAssemblyPlanMapper assemblyDao = SpringContextUtil.getBean(PrAssemblyPlanMapper.class);
        PrDeviceMapper deviceDao = SpringContextUtil.getBean(PrDeviceMapper.class);
        Map<String,Object> planParams = new HashMap<>();
        planParams.put("status",PlanStatusEnum.NORMAL.getCode());
        List<PrAssemblyPlan> list = assemblyDao.selectSome(planParams);
        for (PrAssemblyPlan plan : list) {
            HashMap<String, Object> deviceParams = new HashMap<>();
            deviceParams.put("batchId", plan.getBatchId());
            deviceParams.put("status", DeviceStatus.COMPLETED.getCode());
            Long count = deviceDao.selectSomeCount(deviceParams);
            if(count>plan.number && DateUtil.between(DateUtil.parse(plan.endDate), DateUtil.date(), DateUnit.DAY)>3){
                plan.setStatus(PlanStatusEnum.END.getCode());
                assemblyDao.updateByPrimaryKeySelective(plan);
            }
        }
        log.info("完成 组装计划任务定时检查");
    }
}