刘光辉
118 分钟以前 06f314545ac3514d7ce28939920866ae8188d31c
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
package jnpf.dmsService.search;
 
import lombok.RequiredArgsConstructor;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;
 
import java.util.Locale;
import java.util.UUID;
 
@Service
@RequiredArgsConstructor
public class DmsSearchIndexJobService {
    private final DmsSearchProperties properties;
    private final ApplicationEventPublisher eventPublisher;
 
    public void enqueueContentUpsert(String tenantId, UUID documentId, UUID fileVersionId,
                                     String checksumSha256) {
        if (!properties.isEnabled()) {
            return;
        }
        DmsSearchIndexTask task = new DmsSearchIndexTask();
        task.setTenantId(tenantId);
        task.setDocumentId(documentId);
        task.setFileVersionId(fileVersionId);
        task.setChecksumSha256(checksumSha256 == null
                ? null : checksumSha256.toLowerCase(Locale.ROOT));
        eventPublisher.publishEvent(new DmsSearchIndexJobCreatedEvent(task));
    }
}