package jnpf.dmsService.center;

import jnpf.dmsIntegration.audit.DmsVersionStateAuditRow;
import jnpf.dmsEntity.storage.entity.DmsFileObjectEntity;
import jnpf.dmsEntity.permission.entity.DmsFileVersionEntity;
import jnpf.dmsEntity.center.DmsCenterVersionSnapshot;
import jnpf.dmsEntity.storage.vo.DmsFileUploadVO;
import jnpf.dmsMapper.*;
import jnpf.exception.DataException;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import java.util.UUID;

/** Center reads. Business adapters must not join center tables in their mappers. */
@Service
@RequiredArgsConstructor
public class DmsCenterQueryService {
    private final DmsFileVersionMapper versions;
    private final DmsDocumentMapper documents;
    private final DmsVersionStateMapper states;
    private final DmsFileObjectMapper objects;

    public DmsFileUploadVO registration(String tenantId, String serviceId, String sourceKey) {
        return objects.selectUploadBySource(tenantId, serviceId, sourceKey);
    }

    public DmsCenterVersionSnapshot version(String tenantId, UUID versionId) {
        DmsFileVersionEntity version = versions.selectByTenantAndId(tenantId, versionId);
        if (version == null) return null;
        DmsVersionStateAuditRow state = states.selectAuditState(tenantId, versionId);
        DmsFileObjectEntity object = objects.selectByTenantAndFileVersionId(tenantId, versionId);
        return new DmsCenterVersionSnapshot(version.getDocumentId(), version.getId(), version.getVersionLabel(), version.getChecksumSha256(),
                version.getPreparedBy(), version.getPreparedOn(), object == null ? null : object.getId(),
                state == null ? null : state.getLifecycleStatus(), state == null ? null : state.getEffectiveFrom(),
                state == null ? null : state.getEffectiveTo());
    }

    public void requireUnusedReservation(String tenantId, UUID documentId, UUID versionId, boolean newDocument) {
        if (versions.selectByTenantAndId(tenantId, versionId) != null
                || (newDocument && documents.selectByTenantAndId(tenantId, documentId) != null))
            throw new DataException("旧登记ID已被使用，不能自动替换预留ID");
    }
}