package jnpf.dmsService;

import jnpf.audit.sdk.annotation.AuditLog;
import jnpf.dmsEntity.storage.approval.DmsDisableRequest;
import jnpf.dmsEntity.storage.approval.DmsApprovedBatch;
import jnpf.dmsMapper.DmsApprovedBatchMapper;
import java.nio.charset.StandardCharsets;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import jnpf.dmsMapper.DmsApprovedDisableMapper;
import jnpf.dmsMapper.DmsWenjianZiyuanMapper;
import jnpf.exception.DataException;
import jnpf.flowable.WorkFlowApi;
import jnpf.flowable.entity.TaskEntity;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.*;

/** Short local transactions only. Native forms are read, never created or replaced here. */
@Service
@RequiredArgsConstructor
public class DmsApprovedDisableService {
    private final DmsApprovedDisableMapper mapper;
    private final DmsWenjianZiyuanMapper resources;
    private final WorkFlowApi workflow;
    private final DmsApprovedBatchMapper batches;
    @Value("${dms.approved-disable.enabled:false}") private boolean enabled;

    @Transactional(rollbackFor = Exception.class)
    @AuditLog(action="DMS_QUEUE_APPROVED_DISABLE", bizCodeExpr="#taskId")
    public DmsApprovedBatch enqueue(String tenantId, String flowId, String taskId, String operation) {
        requireEnabled(); requireOperation(operation);
        TaskEntity task = approved(flowId, taskId);
        List<DmsDisableRequest> rows = new ArrayList<>(mapper.nativeRows(tenantId, flowId, taskId, operation));
        if (rows.isEmpty()) throw new DataException("未找到已批准的原生停用申请明细");
        Set<String> files = new HashSet<>();
        Set<String> applications = new HashSet<>();
        rows.sort(Comparator.comparing(DmsDisableRequest::getSourceRowId));
        for (DmsDisableRequest row : rows) {
            applications.add(row.getApplicationId());
            if (!files.add(row.getFileId()) || row.getFileId()==null || row.getBusinessVersionId()==null
                    || row.getDocumentId()==null || row.getFileVersionId()==null || row.getFolderId()==null)
                throw new DataException("停用明细重复或缺少真实文件/版本关联，请先发布并补全表单");
            row.setId(UUID.randomUUID()); row.setApprovedAt(task.getEndTime());
            // getInfoSubmit only returns workflow identity/status; nativeRows resolves its persisted actor.
            if (row.getActorId()==null || row.getActorId().isBlank()) throw new DataException("批准任务缺少操作人");
            row.setScheduledAt(DmsApprovedFileDates.disableScheduled(row.getRequestedAt(), task.getEndTime()));
        }
        if (applications.size()!=1) throw new DataException("流程任务关联了多个停用申请");
        String auditType = auditType(operation);
        String digest = digest(rows);
        DmsApprovedBatch existing = batches.find(tenantId, taskId, auditType);
        if (existing != null) {
            if (!Objects.equals(existing.getSourceDigest(), digest)
                    || !Objects.equals(existing.getApprovedAt(), task.getEndTime())
                    || !Objects.equals(existing.getFlowId(), flowId))
                throw new DataException("批准后的停用来源已改变，停止自动处理");
            return existing;
        }
        DmsApprovedBatch batch = new DmsApprovedBatch();
        batch.setId(UUID.randomUUID()); batch.setTenantId(tenantId); batch.setFlowId(flowId);
        batch.setTaskId(taskId); batch.setAuditType(auditType); batch.setAuditId(rows.get(0).getApplicationId());
        batch.setSourceDigest(digest); batch.setActorId(rows.get(0).getActorId());
        batch.setApprovedAt(task.getEndTime()); batch.setStatus("WAITING");
        batch.setScheduledAt(rows.stream().map(DmsDisableRequest::getScheduledAt).min(Date::compareTo).orElseThrow());
        batches.insertBatch(batch);
        for (DmsDisableRequest row : rows) {
            row.setBatchId(batch.getId());
            resources.selectByIdForUpdate(tenantId, row.getFileId());
            validateTarget(row);
            mapper.enqueue(row);
        }
        return batch;
    }

    // Length prefixes preserve nulls and separators in native IDs; row order is canonical.
    private static String digest(List<DmsDisableRequest> rows) {
        StringBuilder source = new StringBuilder();
        for (DmsDisableRequest row : rows) {
            for (Object value : Arrays.asList(row.getSourceRowId(), row.getApplicationId(), row.getFileId(),
                    row.getBusinessVersionId(), row.getDocumentId(), row.getFileVersionId(), row.getFolderId(),
                    row.getSourceFileId(), row.getSourceVersionId(),
                    row.getRequestedAt() == null ? null : row.getRequestedAt().getTime())) {
                String text = value == null ? null : value.toString();
                source.append(text == null ? -1 : text.length()).append(':');
                if (text != null) source.append(text);
            }
        }
        try { return HexFormat.of().formatHex(MessageDigest.getInstance("SHA-256").digest(source.toString().getBytes(StandardCharsets.UTF_8))); }
        catch (NoSuchAlgorithmException impossible) { throw new IllegalStateException(impossible); }
    }

    static String auditType(String operation) {
        requireOperation(operation);
        return "yichexiao".equals(operation) ? "chexiao_shenqing" : "shixiao_shenqing";
    }

    @Transactional(rollbackFor = Exception.class)
    public void refreshProgress(DmsApprovedBatch batch) {
        requireEnabled();
        if (mapper.refreshProgress(batch) != 1) throw new DataException("统一任务进度更新失败或租约已失效");
    }

    private void validateTarget(DmsDisableRequest row) {
        if (mapper.validateTarget(row)!=1) throw new DataException("业务文件版本或有效状态已改变，不能登记原停用申请");
        if ("yishixiao".equals(row.getOperation()) && mapper.candidateExists(row)<1)
            throw new DataException("该文件不是已生效新增文件检出的同名旧文件");
    }
    private TaskEntity approved(String flowId,String taskId) {
        TaskEntity task=workflow.getInfoSubmit(taskId);
        if (task==null || !taskId.equals(task.getId()) || !Integer.valueOf(2).equals(task.getStatus())
                || task.getEndTime()==null || (!flowId.equals(task.getFlowId()) && !flowId.equals(task.getTemplateId())))
            throw new DataException("文件停用必须先通过真实工作流审批");
        return task;
    }
    static void requireOperation(String operation) {
        if (!"yichexiao".equals(operation) && !"yishixiao".equals(operation)) throw new DataException("文件停用类型无效");
    }
    private void requireEnabled() {
        if (!enabled) throw new DataException("停用推送尚未启用：需先完成技术迁移和原生流程接入");
    }
}