package jnpf.dmsMapper;

import jnpf.dmsEntity.storage.pdf.DmsPdfGenerationTask;
import jnpf.dmsEntity.storage.vo.DmsPersistentPdfGenerateVO;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

import java.util.List;
import java.util.UUID;

@Mapper
public interface DmsPdfGenerationTaskMapper {
    int enqueue(@Param("tenantId") String tenantId, @Param("fileVersionId") UUID fileVersionId,
                @Param("sourceChecksum") String sourceChecksum);
    int requeue(@Param("tenantId") String tenantId, @Param("fileVersionId") UUID fileVersionId,
                @Param("sourceChecksum") String sourceChecksum);
    int clearInvalidPdf(@Param("tenantId") String tenantId,
                        @Param("fileVersionId") UUID fileVersionId,
                        @Param("sourceChecksum") String sourceChecksum,
                        @Param("objectKey") String objectKey);
    int discover(@Param("limit") int limit);
    List<DmsPdfGenerationTask> candidates(@Param("limit") int limit, @Param("maxAttempts") int maxAttempts);
    int claim(@Param("tenantId") String tenantId, @Param("fileVersionId") UUID fileVersionId,
              @Param("token") String token, @Param("maxAttempts") int maxAttempts,
              @Param("leaseSeconds") int leaseSeconds);
    int writePdf(@Param("tenantId") String tenantId, @Param("fileVersionId") UUID fileVersionId,
                 @Param("sourceChecksum") String sourceChecksum,
                 @Param("pdf") DmsPersistentPdfGenerateVO pdf);
    int succeed(@Param("tenantId") String tenantId, @Param("fileVersionId") UUID fileVersionId,
                @Param("token") String token);
    int fail(@Param("tenantId") String tenantId, @Param("fileVersionId") UUID fileVersionId,
             @Param("token") String token, @Param("error") String error,
             @Param("delaySeconds") int delaySeconds, @Param("terminal") boolean terminal);
}