审批流定时任务

xuhy

2025-02-27 bb2309676cefae28bef14d1971ccda4b7dc38ed8

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
package com.ruoyi.system.task.jobs;
 
import com.aizuda.bpm.engine.entity.FlwTaskActor;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.ruoyi.common.core.domain.model.LoginUser;
import com.ruoyi.system.bo.ProcessAgreeBO;
import com.ruoyi.system.task.base.AbstractJob;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
 
import java.util.Objects;
 
/**
 * 发票定时任务
 * @author Administrator
 *
 */
public class StateProcessJob extends AbstractJob {
    
    public static final String name = "stateProcess_";
    
    @Override
    public void execute(JobExecutionContext context)
            throws JobExecutionException {
        JobDataMap maps = context.getMergedJobDataMap();
        Long taskId = maps.getLong("id");
        try {
            System.err.println("执行定时任务");
            ProcessAgreeBO processAgreeBO = new ProcessAgreeBO();
            processAgreeBO.setTaskId(String.valueOf(taskId));
            FlwTaskActor flwTaskActor = flwTaskActorMapper.selectOne(Wrappers.lambdaQuery(FlwTaskActor.class).eq(FlwTaskActor::getTaskId, taskId).last("LIMIT 1"));
            if(Objects.isNull(flwTaskActor)){
                System.err.println("该任务不存在");
                return;
            }
            processAgreeBO.setRemark("自动审批");
            processAgreeBO.setUserId(Long.valueOf(flwTaskActor.getActorId()));
            stateProcessTemplateService.agree(processAgreeBO);
        }catch(Exception e){
            e.printStackTrace();
        }
    }
 
}