package jnpf.flowable.service;

import jnpf.exception.WorkFlowException;
import jnpf.flowable.entity.OperatorEntity;
import jnpf.flowable.entity.TaskEntity;
import jnpf.flowable.entity.TemplateNodeEntity;
import jnpf.flowable.mapper.TaskMapper;
import jnpf.flowable.mapper.TemplateNodeMapper;
import jnpf.flowable.model.filepermission.WorkflowAuditContextResolver;
import jnpf.flowable.util.OperatorUtil;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.Objects;

/** 仅由 DMS 原生保存的专属分支调用；节点名不接受请求自报值。 */
@Service
@RequiredArgsConstructor
public class WorkflowAuditContextResolverImpl implements WorkflowAuditContextResolver {
    private final OperatorUtil operators;
    private final TaskMapper tasks;
    private final TemplateNodeMapper nodes;

    @Override
    public Map<String, String> resolve(String taskId, String formId, String operatorId) throws WorkFlowException {
        OperatorEntity operator = operators.checkOperator(operatorId);
        if (!Objects.equals(taskId, operator.getTaskId()))
            throw new WorkFlowException("文件审计的流程与办理记录不匹配");
        // An authenticated development run has already checked its switch, form allowlist and electronic signer.
        // The scope exists only during the local native save; HTTP callers cannot supply it.
        if (!jnpf.flowable.model.util.DevApprovalActor.active()
                || !jnpf.flowable.model.util.DevApprovalActor.isActing(operatorId, jnpf.util.UserProvider.getLoginUserId()))
            operators.checkOperatorPermission(operatorId);
        TaskEntity task = tasks.getInfo(taskId);
        TemplateNodeEntity node = nodes.getList(task.getFlowId()).stream()
                .filter(n -> Objects.equals(n.getNodeCode(), operator.getNodeCode()))
                .findFirst().orElse(null);
        if (node == null || !Objects.equals(formId, node.getFormId()))
            throw new WorkFlowException("文件审计的表单与办理节点不匹配");
        Map<String, String> context = new LinkedHashMap<>();
        context.put("taskId", taskId);
        context.put("operatorId", operator.getId());
        context.put("nodeId", operator.getNodeId());
        context.put("nodeCode", operator.getNodeCode());
        context.put("nodeName", operator.getNodeName());
        return context;
    }
}