package jnpf.fileStorage.dms;
|
|
import jnpf.dms.DmsPersistentPdfRecoveryApi;
|
import jnpf.dmsEntity.download.model.DmsFileDownloadTicket;
|
import jnpf.dmsEntity.preview.model.DmsFilePreviewTicket;
|
import jnpf.dmsEntity.storage.form.DmsPersistentPdfInvalidationForm;
|
import jnpf.dmsEntity.storage.model.DmsPersistentPdfSource;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
|
import java.util.UUID;
|
|
@Slf4j
|
@Component
|
@RequiredArgsConstructor
|
public class DmsPersistentPdfRecoveryReporter {
|
private static final String SERVICE_ID = "jnpf-file";
|
private final DmsPersistentPdfRecoveryApi recoveryApi;
|
|
public void report(DmsFilePreviewTicket ticket, String reason) {
|
if (ticket == null) return;
|
report(ticket.getTenantId(), ticket.getFileVersionId(), ticket.getPdfSource(), reason);
|
}
|
|
public void report(DmsFileDownloadTicket ticket, String reason) {
|
if (ticket == null) return;
|
report(ticket.getTenantId(), ticket.getFileVersionId(), ticket.getPdfSource(), reason);
|
}
|
|
private void report(String tenantId, UUID fileVersionId, DmsPersistentPdfSource source,
|
String reason) {
|
if (source == null || source.getObjectKey() == null
|
|| source.getSourceChecksumSha256() == null) return;
|
DmsPersistentPdfInvalidationForm form = new DmsPersistentPdfInvalidationForm();
|
form.setTenantId(tenantId);
|
form.setFileVersionId(fileVersionId);
|
form.setSourceChecksumSha256(source.getSourceChecksumSha256());
|
form.setObjectKey(source.getObjectKey());
|
form.setReason(reason);
|
try {
|
recoveryApi.invalidate(SERVICE_ID, form);
|
} catch (Exception exception) {
|
log.warn("上报 DMS 持久化 PDF 失效失败，不影响当前文件访问: fileVersionId={}, objectKey={}",
|
fileVersionId, source.getObjectKey(), exception);
|
}
|
}
|
}
|
