package jnpf.dmsService;

import jnpf.dmsEntity.storage.approval.*;
import jnpf.dmsMapper.DmsApprovedBatchMapper;
import jnpf.exception.DataException;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.*;

@Service
@RequiredArgsConstructor
public class DmsApprovedFileActivationService {
    private final DmsApprovedBatchMapper receipts;
    private final jnpf.dmsService.center.DmsCenterActivationService center;
    private final DmsApprovedAuditSource source;
    private final DmsQianpiyeRenderSnapshotService qianpiyeSnapshots;
    private final DmsApprovedReadAccessService readAccess;
    private final DmsBusinessLifecycleGuard businessOccupancy;

    @Transactional(rollbackFor = Exception.class)
    public DmsApprovedBatch activate(String tenantId, UUID id) {
        DmsApprovedBatch batch = receipts.lock(tenantId, id);
        if (batch == null) throw new DataException("批准文件接收回执不存在");
        if (!"WAITING".equals(batch.getStatus()) && !"FAILED".equals(batch.getStatus())) return batch;
        DmsApprovedAuditSource.Source externalSource = "wailai_wenjian_xinzeng_shenhe".equals(batch.getAuditType())
                ? source.load(tenantId, batch.getFlowId(), batch.getTaskId(), batch.getAuditType(),
                    batch.getActorId(), batch.getApprovedAt()) : null;
        var businessReceipts = externalSource != null
                ? businessOccupancy.requireExternalCreation(tenantId, batch.getAuditId(), batch.getTaskId(),
                    externalSource.batch().getItems().get(0).getDocumentNo())
                : "xiuding_shenhe".equals(batch.getAuditType())
                    ? businessOccupancy.requireRevision(tenantId,batch.getAuditId())
                    : businessOccupancy.requireCreation(tenantId,batch.getAuditId());
        // DB clock is authoritative. An early callback leaves WAITING unchanged.
        if (receipts.activate(tenantId, id) != 1) return batch;
        DmsApprovedBatch activated = receipts.lock(tenantId, id);
        if (activated.getEffectiveTo() != null && !activated.getEffectiveTo().after(activated.getActivatedAt()))
            throw new DataException("文件有效期已结束，不能激活");
        DmsApprovedAuditSource.Source nativeSource = externalSource != null ? externalSource
                : source.load(tenantId, batch.getFlowId(), batch.getTaskId(),
                    batch.getAuditType(), batch.getActorId(), batch.getApprovedAt());
        DmsApprovedBatch currentSource = nativeSource.batch();
        // Activation must not introduce a new render snapshot into files registered before
        // original-document tag filling was enabled; their stored content is already frozen.
        if (batch.getApprovalRenderSnapshot() != null) {
            qianpiyeSnapshots.attach(currentSource, batch.getApprovalRenderSnapshot(),
                    nativeSource.preparedBy(), nativeSource.preparedOn());
        }
        if (!Objects.equals(batch.getSourceDigest(), currentSource.getSourceDigest()))
            throw new DataException("批准后审核内容已改变，不能按旧回执生效");
        List<DmsApprovedItem> items = receipts.items(tenantId, id);
        if (items.size() != currentSource.getItems().size()) throw new DataException("文件接收项目不完整");
        if(businessOccupancy.isEnabled())
            DmsBusinessLifecycleGuard.verifySourceCoverage(businessReceipts,currentSource.getItems());
        center.activate(tenantId, batch.getActorId(), items.stream().map(item ->
                new jnpf.dmsEntity.center.DmsCenterActivation(item.getDocumentId(), item.getFileVersionId(),
                        item.getBaseFileVersionId(), item.getChangeType(), item.getChecksumSha256())).toList());
        readAccess.apply(activated, items, currentSource.getItems());
        return activated;
    }
}