package jnpf.dmsService.center;

import jnpf.audit.sdk.annotation.AuditLog;
import jnpf.dmsEntity.center.DmsCenterDisableCommand;
import jnpf.dmsEntity.center.DmsInvalidationTarget;
import jnpf.dmsEntity.storage.approval.DmsDisableRequest;
import jnpf.dmsMapper.DmsInvalidationMapper;
import jnpf.dmsMapper.DmsRevocationMapper;
import jnpf.exception.DataException;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import java.util.Date;
import java.util.List;
import java.util.UUID;

/** Center transitions participate in the approved item's local transaction. */
@Service
@RequiredArgsConstructor
public class DmsCenterDisableService {
    private final DmsInvalidationMapper mapper;
    private final DmsRevocationMapper revocations;

    /** The caller still completes the approved item and releases its own receipts in the same transaction.
     * Elapsed validity is sufficient even while the lowest-priority expiry task is waiting for that receipt.
     * This check never rewrites the existing invalidation reason, validity interval or directory members.
     */
    @Transactional(propagation = Propagation.MANDATORY)
    public boolean alreadyIneffective(DmsCenterDisableCommand command, DmsDisableRequest row, Date at) {
        List<UUID> documents = mapper.lockDocuments(command);
        if (documents.isEmpty() || documents.size() > 1000)
            throw new DataException("执行目录不存在或成员超过1000个");
        if (mapper.hasPendingVersions(command))
            throw new DataException("目录存在待批准、待生效或未完成业务回写的版本，暂不结束任务");
        Boolean ineffective = mapper.alreadyIneffective(row, at);
        if (ineffective == null)
            throw new DataException("执行目标已换版、缺失或资源与中心状态不一致，不能认定任务成功");
        return ineffective;
    }

    @Transactional(propagation = Propagation.MANDATORY)
    @AuditLog(action = "DMS_INVALIDATE_CENTER", bizCodeExpr = "#command.requestId")
    public List<DmsInvalidationTarget> invalidate(DmsCenterDisableCommand command, Date at) {
        if (!"yishixiao".equals(command.getReason())) throw new DataException("该入口只执行已批准的文件失效");
        List<UUID> documents = mapper.lockDocuments(command);
        if (documents.isEmpty() || documents.size() > 1000 || !mapper.validDirectory(command))
            throw new DataException("失效专属目录不存在、已停用、归属已变化或成员超过1000个");
        if (mapper.hasPendingVersions(command))
            throw new DataException("目录存在待批准、待生效或未完成业务回写的版本，暂不执行失效");
        List<DmsInvalidationTarget> targets = mapper.currentTargets(command);
        if (targets.size() > 1000 || targets.stream().noneMatch(t -> command.getMainDocumentId().equals(t.getDocumentId())
                && command.getExpectedMainVersionId().equals(t.getFileVersionId())))
            throw new DataException("失效主文件已不是申请登记的现行有效版本");
        for (DmsInvalidationTarget target : targets) {
            if (target.getEffectiveFrom() == null || !at.after(target.getEffectiveFrom())
                    || mapper.invalidateVersion(command, target, at) != 1)
                throw new DataException("失效版本或有效时间已变化，请重试");
        }
        if (mapper.markDocuments(command, at) != documents.size())
            throw new DataException("失效目录成员已变化，请重试");
        return targets;
    }

    @Transactional(propagation = Propagation.MANDATORY)
    @AuditLog(action = "DMS_REVOKE_CENTER", bizCodeExpr = "#command.requestId")
    public List<DmsInvalidationTarget> revoke(DmsCenterDisableCommand command, Date at) {
        if (!"yichexiao".equals(command.getReason())) throw new DataException("该入口只执行已批准的文件撤销");
        List<UUID> documents = revocations.lockDocuments(command);
        if (documents.isEmpty() || documents.size() > 1000 || !revocations.validDirectory(command))
            throw new DataException("撤销专属目录不存在、已停用、归属已变化或成员超过1000个");
        if (revocations.hasPendingVersions(command))
            throw new DataException("目录存在待批准、待生效或未完成业务回写的版本，暂不执行撤销");
        List<DmsInvalidationTarget> targets = revocations.currentTargets(command);
        if (targets.size() > 1000 || targets.stream().noneMatch(t -> command.getMainDocumentId().equals(t.getDocumentId())
                && command.getExpectedMainVersionId().equals(t.getFileVersionId())))
            throw new DataException("撤销主文件已不是申请登记的最新版本，或已被其他操作停用");
        for (DmsInvalidationTarget target : targets) {
            if (target.getEffectiveFrom() == null || !at.after(target.getEffectiveFrom())
                    || revocations.revokeVersion(command, target, at) != 1)
                throw new DataException("撤销版本或有效时间已变化，请重试");
        }
        if (revocations.markDocuments(command, at) != documents.size())
            throw new DataException("撤销目录成员已变化，请重试");
        return targets;
    }
}