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.entity.SysUser;
|
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);
|
// 短信发送
|
SysUser sysUser = sysUserService.selectUserById(Long.valueOf(flwTaskActor.getActorId()));
|
smsUtil.sendSms(sysUser.getPhonenumber(), "2369951", new String[]{});
|
}catch(Exception e){
|
e.printStackTrace();
|
}
|
}
|
|
}
|
