package org.springblade.mdm.flow.service.execute;
|
|
import io.swagger.v3.oas.annotations.Parameter;
|
import org.flowable.engine.RuntimeService;
|
import org.flowable.engine.TaskService;
|
import org.flowable.task.api.Task;
|
import org.springblade.core.tool.api.R;
|
import org.springblade.mdm.flow.constants.FlowContants;
|
import org.springblade.mdm.flow.service.ApproveRecordService;
|
import org.springblade.system.feign.IUserClient;
|
import org.springblade.system.pojo.entity.User;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.RequestBody;
|
|
import java.util.Map;
|
|
/**
|
* 任务完成接口
|
*/
|
@Service
|
public abstract class AbstractFlowCompleteService {
|
@Autowired
|
protected TaskService taskService;
|
@Autowired
|
protected RuntimeService runtimeService;
|
@Autowired
|
protected ApproveRecordService approveRecordService;
|
|
@Transactional
|
public abstract void completeTask(String taskId, String processInstanceId, String comment, @Parameter(name = "variables", description = "流程变量") @RequestBody Map<String, Object> variables);
|
|
/**
|
* 获取审批结果 Y/N
|
* @param variables 前端提交的变量map
|
* @return Y/N 字符串
|
*/
|
protected String getApproveResult(Map<String, Object> variables){
|
return variables.get("approve")+"";
|
}
|
/**
|
* 获取当前正在执行的任务
|
* @param taskId 任务id
|
* @return 任务实体
|
*/
|
Task currentTask(String taskId) {
|
return taskService.createTaskQuery()
|
.taskId(taskId)
|
.singleResult();
|
}
|
void addApproveRecord(String taskId,String comment,Map<String, Object> variables){
|
String operateResult = variables.get("approve")+"";
|
approveRecordService.saveApproveRecords(currentTask(taskId),operateResult,comment);
|
}
|
|
|
}
|
