package jnpf.dmsService.pdf;

import jnpf.dmsEntity.storage.pdf.DmsPdfGenerationTask;
import jnpf.dmsEntity.storage.vo.DmsPersistentPdfGenerateVO;
import jnpf.dmsMapper.DmsPdfGenerationTaskMapper;
import jnpf.exception.DataException;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
@RequiredArgsConstructor
public class DmsPdfGenerationCompletion {
    private final DmsPdfGenerationTaskMapper mapper;

    @Transactional(rollbackFor = Exception.class)
    public void succeed(DmsPdfGenerationTask task, String token, DmsPersistentPdfGenerateVO pdf) {
        if (pdf == null || pdf.getObjectKey() == null || pdf.getSizeBytes() == null
                || pdf.getChecksumSha256() == null || pdf.getSourceChecksumSha256() == null) {
            throw new DataException("持久化 PDF 返回结果不完整");
        }
        if (mapper.writePdf(task.getTenantId(), task.getFileVersionId(),
                task.getSourceChecksumSha256(), pdf) != 1) {
            throw new DataException("源文件已变化，拒绝写入过期 PDF");
        }
        if (mapper.succeed(task.getTenantId(), task.getFileVersionId(), token) != 1) {
            throw new DataException("持久化 PDF 任务租约已失效");
        }
    }
}