package jnpf.dmsService;

import jnpf.audit.sdk.annotation.AuditLog;
import jnpf.dmsEntity.storage.approval.DmsDisableOccupancy;
import jnpf.dmsMapper.DmsDisableApplicationMapper;
import jnpf.exception.DataException;
import jnpf.dmsEntity.storage.form.DmsDisableSubmitValidationForm;
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.HashSet;
import java.util.List;
import java.util.Objects;
import java.util.Set;

/** Workflow-event side effect only; native forms still own application persistence. */
@Service
@RequiredArgsConstructor
public class DmsDisableOccupancyService {
    private static final Set<Integer> RELEASED = Set.of(3, 4, 7, 9);
    private final DmsDisableApplicationMapper mapper;
    private final WorkFlowApi workflow;
    @Value("${dms.disable-occupancy.enabled:false}")
    private boolean enabled;

    @Transactional(rollbackFor = Exception.class)
    @AuditLog(action = "DMS_SYNC_DISABLE_OCCUPANCY", bizCodeExpr = "#taskId")
    public boolean onEvent(String tenantId, String flowId, String taskId, String operation, String eventType) {
        DmsApprovedDisableService.requireOperation(operation);
        if (!Set.of("start", "end", "back", "reject", "recall").contains(eventType))
            throw new DataException("不支持的文件占用流程事件");
        if (!enabled && !"end".equals(eventType)) throw new DataException("文件占用登记尚未启用，需先完成技术迁移及流程事件配置");
        TaskEntity task = workflow.getInfoSubmit(taskId);
        if (task == null || !taskId.equals(task.getId()) || task.getStatus() == null
                || (!flowId.equals(task.getFlowId()) && !flowId.equals(task.getTemplateId())))
            throw new DataException("文件占用事件与真实工作流任务不匹配");
        DmsDisableOccupancy application = mapper.application(tenantId, taskId, operation);
        if (application == null || (!Objects.equals(application.getFlowId(), task.getFlowId())
                && !Objects.equals(application.getFlowId(), task.getTemplateId()))
                || !Objects.equals(application.getFlowState(), task.getStatus()))
            throw new DataException("文件占用事件与原生申请归属或流程状态不匹配");
        if (RELEASED.contains(task.getStatus()) && task.getEndTime() != null) {
            if (enabled) mapper.releaseTask(tenantId, taskId, operation);
            return false;
        }
        if ("end".equals(eventType)) return task.getStatus() == 2 && task.getEndTime() != null;
        // Returned or recalled but unfinished workflows keep their existing snapshot.
        if (!"start".equals(eventType) || !Set.of(1, 5, 6, 10).contains(task.getStatus())) return false;
        List<DmsDisableOccupancy> rows = mapper.applicationFiles(tenantId, application.getApplicationId(), operation);
        if (rows.isEmpty()) throw new DataException("原生撤销或失效申请没有主文件明细");
        Set<String> files = new HashSet<>();
        for (DmsDisableOccupancy row : rows) {
            if (row.getFileId() == null || row.getFileId().isBlank() || row.getFolderId() == null || row.getFolderId().isBlank() || !files.add(row.getFileId()))
                throw new DataException("申请明细重复或缺少有效主文件/专属目录关联");
        }
        requireAvailable(tenantId, files.stream().toList(), taskId);
        // One local transaction replaces this task's snapshot; no cross-workflow exclusive lock.
        mapper.releaseTask(tenantId, taskId, operation);
        for (DmsDisableOccupancy row : rows) {
            row.setTenantId(tenantId);
            row.setOperation(operation);
            row.setApplicationId(application.getApplicationId());
            row.setFlowId(task.getFlowId());
            row.setTaskId(taskId);
            mapper.occupy(row);
        }
        return false;
    }
    public void validateSubmission(String tenantId, String userId, String operation, DmsDisableSubmitValidationForm form) {
        DmsApprovedDisableService.requireOperation(operation);
        if (!enabled) throw new DataException("文件占用登记尚未启用，不能提交撤销或失效申请");
        List<String> files = form.getFileIds();
        if (files == null || files.isEmpty() || files.stream().anyMatch(id -> id == null || id.isBlank())
                || new HashSet<>(files).size() != files.size())
            throw new DataException("请至少选择一个主文件，同一文件不能重复申请");
        String ownTask = null;
        if (form.getTaskId() != null && !form.getTaskId().isBlank()) {
            TaskEntity task = workflow.getInfoSubmit(form.getTaskId());
            DmsDisableOccupancy application = mapper.application(tenantId, form.getTaskId(), operation);
            if (task == null || !form.getTaskId().equals(task.getId()) || application == null
                    || (!form.getFlowId().equals(task.getFlowId()) && !form.getFlowId().equals(task.getTemplateId()))
                    || (!Objects.equals(application.getFlowId(), task.getFlowId()) && !Objects.equals(application.getFlowId(), task.getTemplateId()))
                    || task.getStatus() == null || !Set.of(0,1,5,6,8,9,10).contains(task.getStatus()) || task.getEndTime() != null)
                throw new DataException("仅可沿用本人未结束的原申请，不能排除其他申请的占用");
            if (Set.of(0,8,9).contains(task.getStatus())) {
                if (userId == null || userId.isBlank() || !Objects.equals(userId, application.getCreatorUserId()))
                    throw new DataException("仅可沿用本人未结束的原申请");
            } else {
                // Native beforeSubmit is also invoked for approval. Only an unchanged
                // persisted file selection may reuse an in-progress task's snapshot.
                Set<String> persisted = new HashSet<>();
                for (DmsDisableOccupancy row : mapper.applicationFiles(tenantId,application.getApplicationId(),operation))
                    persisted.add(row.getFileId());
                if (!persisted.equals(new HashSet<>(files)))
                    throw new DataException("审批中的文件明细与原申请不一致，不能变更占用范围");
            }
            ownTask = task.getId();
        }
        requireAvailable(tenantId, files, ownTask);
    }

    private void requireAvailable(String tenantId, List<String> files, String ownTask) {
        if (mapper.selectedFiles(tenantId, files).size() != files.size())
            throw new DataException("所选文件已停用、不是有效主文件或缺少专属目录，请重新选择");
        if (mapper.conflictingFiles(tenantId, files, ownTask) > 0)
            throw new DataException("所选文件已有未结束的撤销或失效申请，不能重复提交");
    }

}