package jnpf.flowable.service.dev;
|
|
import com.baomidou.dynamic.datasource.annotation.DSTransactional;
|
import jnpf.exception.WorkFlowException;
|
import jnpf.base.model.flow.FlowFormDataModel;
|
import jnpf.flowable.service.OperatorService;
|
import jnpf.flowable.model.templatenode.nodejson.NodeModel;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.Map;
|
import jnpf.flowable.entity.OperatorEntity;
|
import jnpf.flowable.model.task.FlowModel;
|
import jnpf.flowable.model.util.DevApprovalActor;
|
import jnpf.flowable.model.util.FlowContextHolder;
|
import jnpf.flowable.util.OperatorUtil;
|
import jnpf.flowable.util.ServiceUtil;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
|
import java.util.Date;
|
|
/** Transaction boundary identical to native automatic approval, followed by normal event dispatch. */
|
@Service
|
@RequiredArgsConstructor
|
public class DevApprovalStep {
|
private final OperatorUtil operatorUtil;
|
private final ServiceUtil serviceUtil;
|
private final OperatorService operatorService;
|
|
@DSTransactional
|
public void approve(OperatorEntity operator, FlowModel model, String actorId) throws WorkFlowException {
|
try (DevApprovalActor ignored = DevApprovalActor.open(operator.getId(), actorId, operator.getTaskId())) {
|
if (operator.getSignTime() == null) operator.setSignTime(new Date());
|
if (operator.getStartHandleTime() == null) operator.setStartHandleTime(new Date());
|
operatorService.updateById(operator);
|
NodeModel node = model.getNodes().get(operator.getNodeCode());
|
var definition = model.getNodeEntityList().stream()
|
.filter(n -> operator.getNodeCode().equals(n.getNodeCode())).findFirst().orElseThrow();
|
FlowFormDataModel form = new FlowFormDataModel();
|
form.setFormId(definition.getFormId());
|
form.setId(operator.getTaskId());
|
form.setFlowId(model.getTaskEntity().getFlowId());
|
form.setWorkflowOperatorId(operator.getId());
|
form.setMap(model.getFormData());
|
// Native persistence still enforces field rights; ensure the run's real signature is saved.
|
var permissions = new ArrayList<Map<String, Object>>();
|
if (node.getFormOperates() != null) for (Map<String, Object> permission : node.getFormOperates()) {
|
var copy = new HashMap<>(permission);
|
if ("biz_sign".equals(copy.get("id")) || Boolean.TRUE.equals(copy.get("required"))) copy.put("write", true);
|
permissions.add(copy);
|
}
|
form.setFormOperates(permissions);
|
serviceUtil.saveOrUpdateFormData(form);
|
var saved = serviceUtil.infoData(definition.getFormId(), operator.getTaskId());
|
var missing = DevApprovalValidation.missing(node, saved);
|
if (!missing.isEmpty()) throw new WorkFlowException("原生保存后仍有必填项为空：" + String.join("；", missing));
|
model.setFormData(saved);
|
FlowContextHolder.addChildData(operator.getTaskId(), definition.getFormId(), saved, node.getFormOperates(), false);
|
// Use native system-approval semantics; preserve the original assignee on the task.
|
operatorUtil.audit(operator, model);
|
FlowContextHolder.deleteFormOperator();
|
serviceUtil.handleFormData(model.getTaskEntity().getFlowId(), true);
|
}
|
}
|
}
|
