package jnpf.dmsService.search;
|
|
import jnpf.dmsMapper.DmsDocumentMapper;
|
import jnpf.dmsMapper.DmsSearchIndexSourceMapper;
|
import jnpf.dmsService.search.meili.DmsMeilisearchClient;
|
import jnpf.dmsService.search.meili.DmsSearchIndexDocument;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import java.io.IOException;
|
import java.util.UUID;
|
|
@Service
|
@RequiredArgsConstructor
|
public class DmsSearchIndexWriter {
|
private final DmsDocumentMapper documents;
|
private final DmsSearchIndexSourceMapper sources;
|
private final DmsMeilisearchClient client;
|
|
/** Serialize final submission with expiry so late extraction cannot resurrect a deleted index entry. */
|
@Transactional(rollbackFor = Exception.class)
|
public void publish(DmsSearchIndexDocument document) throws IOException {
|
UUID documentId = UUID.fromString(document.getDocumentId());
|
UUID versionId = UUID.fromString(document.getFileVersionId());
|
if (documents.selectByTenantAndIdForUpdate(document.getTenantId(), documentId) == null) return;
|
if (sources.selectSource(document.getTenantId(), documentId, versionId) == null) return;
|
client.upsert(document);
|
}
|
}
|
