package jnpf.dmsService;

import jnpf.audit.sdk.annotation.AuditLog;
import jnpf.base.UserInfo;
import jnpf.dmsEntity.permission.entity.DmsFileVersionEntity;
import jnpf.dmsEntity.permission.enums.DmsPermissionAction;
import jnpf.dmsEntity.permission.enums.DmsResourceType;
import jnpf.dmsEntity.storage.form.DmsFileExtendValidityForm;
import jnpf.dmsEntity.storage.form.DmsFileExtendValidityForm.FileRequest;
import jnpf.dmsMapper.DmsDocumentMapper;
import jnpf.dmsMapper.DmsFileVersionMapper;
import jnpf.dmsMapper.DmsVersionStateMapper;
import jnpf.dmsPermission.DmsCurrentIdentity;
import jnpf.exception.DataException;
import jnpf.flowable.entity.TaskEntity;
import jnpf.flowable.enums.TaskStatusEnum;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.HashSet;
import java.util.Set;
import java.util.TreeSet;
import java.util.UUID;

@Service
@RequiredArgsConstructor
public class DmsFileValidityService {
    private final DmsCurrentIdentity currentIdentity;
    private final DmsPermissionDecisionService decisionService;
    private final DmsWorkflowFileActivationService workflowService;
    private final DmsFileVersionMapper fileVersionMapper;
    private final DmsDocumentMapper documentMapper;
    private final DmsVersionStateMapper versionStateMapper;
    private final DmsFileValidityProjection projection;
    private final DmsBusinessLifecycleGuard businessOccupancy;

    @Transactional(rollbackFor = Exception.class)
    @AuditLog(action = "UPDATE", label = "批量调整文件有效期", bizModule = "DMS",
            bizType = "DMS_FILE_VERSION", bizCodeExpr = "", bizCodeRequired = false,
            targetTable = "dms_version_states", targetIdExpr = "#p0.files[0].fileVersionId",
            targetIdsExpr = "#p0.files.![fileVersionId]",
            extraExpr = "{'sourceId': #p0.sourceId, 'taskId': #p0.taskId, 'files': #p0.files}")
    public void extendValidity(DmsFileExtendValidityForm form) {
        validateRequest(form);
        UserInfo user = currentIdentity.requireUser();
        String tenantId = currentIdentity.tenantId(user);
        boolean withWorkflow = form.getSourceId() != null && !form.getSourceId().trim().isEmpty();
        if (withWorkflow) {
            TaskEntity task = workflowService.requireTask(form.getSourceId().trim(), form.getTaskId().trim());
            if (!TaskStatusEnum.PASSED.getCode().equals(task.getStatus())) {
                throw new DataException("流程任务尚未审核通过，不能更新有效期");
            }
        }

        businessOccupancy.guardValidity(tenantId,withWorkflow ? form.getTaskId().trim() : null,
                form.getFiles().stream().map(f->f.getFileVersionId().toString()).toList());
        Set<UUID> documentIds = new TreeSet<>();
        for (FileRequest file : form.getFiles()) {
            decisionService.requireAllowed(DmsResourceType.FILE_VERSION, file.getFileVersionId(),
                    DmsPermissionAction.UPDATE);
            DmsFileVersionEntity version = fileVersionMapper.selectByTenantAndId(tenantId, file.getFileVersionId());
            if (version == null) {
                throw new DataException("文件版本不存在：" + file.getFileVersionId());
            }
            documentIds.add(version.getDocumentId());
        }
        // 按统一顺序锁定文档，与修订、激活互斥，避免并发批次反向加锁。
        for (UUID documentId : documentIds) {
            if (documentMapper.selectByTenantAndIdForUpdate(tenantId, documentId) == null) {
                throw new DataException("文件所属文档不存在：" + documentId);
            }
        }
        for (FileRequest file : form.getFiles()) {
            int updated = versionStateMapper.updateCurrentEffectiveTo(tenantId, file.getFileVersionId(), file.getEffectiveTo());
            if (updated != 1) {
                throw new DataException("文件有效期更新失败：" + file.getFileVersionId()
                        + "，文件已过期或不是现行有效版本，或新截止时间未延长");
            }
            projection.apply(tenantId, file.getFileVersionId(), file.getEffectiveTo(), user.getUserId());
        }
    }

    private void validateRequest(DmsFileExtendValidityForm form) {
        if (form == null || form.getFiles() == null || form.getFiles().isEmpty()) {
            throw new DataException("文件请求列表不能为空");
        }
        if (!form.isWorkflowPairValid()) {
            throw new DataException("sourceId和taskId必须同时提供或同时为空");
        }
        Set<UUID> ids = new HashSet<>();
        for (FileRequest file : form.getFiles()) {
            if (file == null || file.getFileVersionId() == null || file.getEffectiveTo() == null) {
                throw new DataException("文件版本ID和有效期至不能为空");
            }
            if (!ids.add(file.getFileVersionId())) {
                throw new DataException("文件版本ID不能重复：" + file.getFileVersionId());
            }
        }
    }
}