package jnpf.flowable.job;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import jnpf.base.UserInfo;
|
import jnpf.config.ConfigValueUtil;
|
import jnpf.database.util.TenantDataSourceUtil;
|
import jnpf.exception.WorkFlowException;
|
import jnpf.flowable.entity.OperatorEntity;
|
import jnpf.flowable.entity.TaskEntity;
|
import jnpf.flowable.model.task.FlowMethod;
|
import jnpf.flowable.model.task.FlowModel;
|
import jnpf.flowable.model.templatenode.nodejson.NodeModel;
|
import jnpf.flowable.model.time.FlowTimeModel;
|
import jnpf.flowable.model.util.FlowNature;
|
import jnpf.flowable.service.OperatorService;
|
import jnpf.flowable.service.TaskService;
|
import jnpf.flowable.util.ConditionUtil;
|
import jnpf.flowable.util.FlowUtil;
|
import jnpf.flowable.util.OperatorUtil;
|
import jnpf.flowable.util.ServiceUtil;
|
import jnpf.permission.entity.UserEntity;
|
import jnpf.util.RedisUtil;
|
import jnpf.util.UserProvider;
|
import jnpf.util.context.SpringContext;
|
import lombok.extern.slf4j.Slf4j;
|
import org.quartz.JobExecutionContext;
|
import org.quartz.JobExecutionException;
|
import org.springframework.scheduling.quartz.QuartzJobBean;
|
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 类的描述
|
*
|
* @author JNPF@YinMai Info. Co., Ltd
|
* @version 5.0.x
|
* @since 2024/5/23 17:42
|
*/
|
@Slf4j
|
public class AutoAuditJob extends QuartzJobBean {
|
|
private static RedisUtil redisUtil;
|
private static ConditionUtil conditionUtil;
|
private static OperatorUtil operatorUtil;
|
private static FlowUtil flowUtil;
|
private static ServiceUtil serviceUtil;
|
private static ConfigValueUtil configValueUtil;
|
private static OperatorService operatorService;
|
private static TaskService taskService;
|
|
static {
|
redisUtil = SpringContext.getBean(RedisUtil.class);
|
configValueUtil = SpringContext.getBean(ConfigValueUtil.class);
|
operatorService = SpringContext.getBean(OperatorService.class);
|
conditionUtil = SpringContext.getBean(ConditionUtil.class);
|
operatorUtil = SpringContext.getBean(OperatorUtil.class);
|
flowUtil = SpringContext.getBean(FlowUtil.class);
|
taskService = SpringContext.getBean(TaskService.class);
|
serviceUtil = SpringContext.getBean(ServiceUtil.class);
|
}
|
|
@Override
|
protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
|
List<FlowTimeModel> list = FlowJobUtil.getOperator(redisUtil);
|
if (CollectionUtil.isNotEmpty(list)) {
|
for (FlowTimeModel timeModel : list) {
|
FlowModel flowModel = timeModel.getFlowModel();
|
Map<String, Object> formData = flowModel.getFormData();
|
String deploymentId = flowModel.getDeploymentId();
|
Map<String, NodeModel> nodes = flowModel.getNodes();
|
|
UserInfo userInfo = flowModel.getUserInfo();
|
if (configValueUtil.isMultiTenancy()) {
|
TenantDataSourceUtil.switchTenant(userInfo.getTenantId());
|
}
|
|
TaskEntity taskEntity = taskService.getById(timeModel.getTaskId());
|
if (null == taskEntity) {
|
taskEntity = flowModel.getTaskEntity();
|
}
|
|
String operatorId = timeModel.getOperatorId();
|
try {
|
OperatorEntity operator = operatorService.getInfo(operatorId);
|
if (null != operator) {
|
if (ObjectUtil.equals(operator.getCompletion(), FlowNature.Action)) {
|
continue;
|
}
|
flowModel.setTaskEntity(taskEntity);
|
if (operator.getSignTime() == null) {
|
operator.setSignTime(new Date());
|
}
|
if (operator.getStartHandleTime() == null) {
|
operator.setStartHandleTime(new Date());
|
}
|
FlowMethod flowMethod = new FlowMethod();
|
flowMethod.setTaskEntity(taskEntity);
|
flowMethod.setFormData(formData == null ? new HashMap<>() : formData);
|
flowMethod.setDeploymentId(deploymentId);
|
flowMethod.setNodeCode(operator.getNodeCode());
|
flowMethod.setNodes(nodes);
|
// 判断节点的线的条件
|
Map<String, Boolean> resMap = conditionUtil.handleCondition(flowMethod);
|
try {
|
conditionUtil.checkCondition(resMap, nodes);
|
} catch (WorkFlowException e) {
|
continue;
|
}
|
List<NodeModel> nextApprover;
|
boolean mark = true;
|
try {
|
nextApprover = flowUtil.getNextApprover(flowMethod);
|
} catch (WorkFlowException e) {
|
nextApprover = null;
|
mark = false;
|
}
|
if (!mark) {
|
continue;
|
}
|
NodeModel nodeModel = nodes.get(operator.getNodeCode());
|
if (!flowUtil.checkBranch(nodeModel) && flowUtil.checkNextCandidates(nextApprover) && flowUtil.checkNextError(flowModel, nextApprover, false, false) == 0) {
|
String handleId = operator.getHandleId();
|
String username = "";
|
UserEntity user = serviceUtil.getUserInfo(handleId);
|
if (user != null) {
|
username = user.getAccount() + "(" + user.getRealName() + ")";
|
}
|
String str = ObjectUtil.equals(operator.getIsProcessing(), FlowNature.NotProcessing) ? "自动审批通过" : "自动办理通过";
|
flowModel.setHandleOpinion(username + str);
|
UserEntity userEntity = serviceUtil.getUserInfo(operator.getHandleId());
|
if (null != userEntity) {
|
userInfo.setUserId(userEntity.getId());
|
userInfo.setUserName(userEntity.getRealName());
|
userInfo.setUserAccount(userEntity.getAccount());
|
}
|
//自动审批，处理签收、办理时间
|
UserProvider.setLoginUser(userInfo);
|
UserProvider.setLocalLoginUser(userInfo);
|
operatorService.updateById(operator);
|
operatorService.auditWithCheck(operator.getId(), flowModel);
|
operatorUtil.handleEvent();
|
operatorUtil.handleTaskStatus();
|
operatorUtil.handleOperator();
|
}
|
}
|
} catch (Exception e) {
|
log.error("超时自动审批异常", e);
|
try {
|
operatorUtil.compensate(taskEntity);
|
} catch (Exception ex) {
|
log.error("超时自动审批补偿异常", ex);
|
}
|
} finally {
|
//TimeUtil.deleteJob(timeModel.getId());
|
FlowJobUtil.remove(timeModel, redisUtil);
|
}
|
}
|
}
|
|
}
|
}
|
