package jnpf.dmsService.center;
|
|
import jnpf.dmsIntegration.audit.DmsBusinessChangeAudit;
|
import static jnpf.dmsIntegration.audit.DmsBusinessChangeAudit.values;
|
|
import jnpf.dmsEntity.permission.entity.DmsDocumentEntity;
|
import jnpf.dmsMapper.DmsDocumentMapper;
|
import jnpf.exception.DataException;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import java.util.*;
|
|
/** Dedicated logical directory ownership. Historical records retain their membership. */
|
@Service
|
@RequiredArgsConstructor
|
public class DmsCenterDirectoryService {
|
private final DmsBusinessChangeAudit businessAudit;
|
private final DmsDocumentMapper documents;
|
|
@Transactional(rollbackFor = Exception.class)
|
public void bind(String tenantId, UUID mainDocumentId, Collection<UUID> recordDocumentIds) {
|
if (tenantId == null || tenantId.isBlank() || mainDocumentId == null || recordDocumentIds == null
|
|| recordDocumentIds.stream().anyMatch(Objects::isNull) || recordDocumentIds.contains(mainDocumentId))
|
throw new DataException("文件目录归属请求无效");
|
Set<UUID> ids = new TreeSet<>(); ids.add(mainDocumentId); ids.addAll(recordDocumentIds);
|
Map<UUID, DmsDocumentEntity> locked = new HashMap<>();
|
for (UUID id : ids) {
|
DmsDocumentEntity document = documents.selectByTenantAndIdForUpdate(tenantId, id);
|
if (document == null) throw new DataException("文件目录成员不存在");
|
locked.put(id, document);
|
}
|
DmsDocumentEntity main = locked.get(mainDocumentId);
|
if (main.getMainDocumentId() != null) throw new DataException("记录文件不能作为主文件目录");
|
for (UUID id : recordDocumentIds) {
|
DmsDocumentEntity record = locked.get(id);
|
if (!Objects.equals(main.getFolderId(), record.getFolderId()))
|
throw new DataException("记录与主文件的上级目录不一致");
|
if (record.getMainDocumentId() != null) {
|
if (!mainDocumentId.equals(record.getMainDocumentId()))
|
throw new DataException("记录已属于其他主文件目录");
|
continue;
|
}
|
if (documents.countRecords(tenantId, id) != 0)
|
throw new DataException("已有记录的主文件不能转为记录");
|
if (documents.bindMainDocument(tenantId, id, mainDocumentId) != 1)
|
throw new DataException("记录目录归属发生变化");
|
businessAudit.record(tenantId, "DMS_CENTER_BIND_DIRECTORY", "记录文件归属绑定", "dms_documents", id.toString(),
|
values("main_document_id", record.getMainDocumentId()), values("main_document_id", mainDocumentId),
|
null, values("document_id", id, "main_document_id", mainDocumentId));
|
}
|
}
|
}
|
