From 0ab9dfd8f122195e4e9f09bd50c59e0a47450bec Mon Sep 17 00:00:00 2001 From: mitao <2763622819@qq.com> Date: 星期三, 19 三月 2025 15:50:03 +0800 Subject: [PATCH] fix: resolve merge conflicts in .gitignore --- ruoyi-system/src/main/java/com/ruoyi/system/task/jobs/StateProcessJob.java | 49 +++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 49 insertions(+), 0 deletions(-) diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/task/jobs/StateProcessJob.java b/ruoyi-system/src/main/java/com/ruoyi/system/task/jobs/StateProcessJob.java new file mode 100644 index 0000000..0f2d909 --- /dev/null +++ b/ruoyi-system/src/main/java/com/ruoyi/system/task/jobs/StateProcessJob.java @@ -0,0 +1,49 @@ +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(); + } + } + +} -- Gitblit v1.7.1