package jnpf.dmsService.center;
|
|
import jnpf.dmsIntegration.audit.DmsBusinessChangeAudit;
|
import static jnpf.dmsIntegration.audit.DmsBusinessChangeAudit.values;
|
|
import jnpf.dmsEntity.permission.entity.DmsFileVersionEntity;
|
|
import jnpf.dmsEntity.center.DmsCenterActivation;
|
import jnpf.dmsEntity.permission.entity.DmsDocumentEntity;
|
import jnpf.dmsMapper.*;
|
import jnpf.dmsService.search.DmsSearchIndexJobService;
|
import jnpf.exception.DataException;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import java.util.*;
|
|
/** Atomic center state transitions; no native form, workflow API or business queue dependency. */
|
@Service
|
@RequiredArgsConstructor
|
public class DmsCenterActivationService {
|
private final DmsBusinessChangeAudit businessAudit;
|
private final DmsDocumentMapper documents;
|
private final DmsFileVersionMapper versions;
|
private final DmsVersionStateMapper states;
|
private final DmsSearchIndexJobService search;
|
|
@Transactional(rollbackFor = Exception.class)
|
public void activate(String tenantId, String actorId, List<DmsCenterActivation> targets) {
|
if (tenantId == null || tenantId.isBlank() || actorId == null || actorId.isBlank()
|
|| targets == null || targets.isEmpty()) throw new DataException("中心生效请求不完整");
|
Set<UUID> seen = new HashSet<>();
|
for (DmsCenterActivation target : targets) {
|
if (target == null || target.documentId() == null || target.fileVersionId() == null
|
|| !Set.of("CREATE", "REVISE", "REUSE", "RETIRE").contains(target.operation())
|
|| !seen.add(target.documentId())) throw new DataException("中心生效目标无效或重复");
|
}
|
List<DmsCenterActivation> ordered = targets.stream().sorted(Comparator.comparing(t -> t.documentId().toString())).toList();
|
Map<UUID, DmsDocumentEntity> locked = new HashMap<>();
|
for (DmsCenterActivation target : ordered) {
|
DmsDocumentEntity document = documents.selectByTenantAndIdForUpdate(tenantId, target.documentId());
|
if (document == null)
|
throw new DataException("接收文件不存在");
|
locked.put(target.documentId(), document);
|
}
|
for (DmsCenterActivation target : ordered) {
|
if (!"RETIRE".equals(target.operation())) continue;
|
UUID mainId = locked.get(target.documentId()).getMainDocumentId();
|
if (mainId == null || !locked.containsKey(mainId)
|
|| locked.get(mainId).getMainDocumentId() != null
|
|| targets.stream().noneMatch(t -> mainId.equals(t.documentId())
|
&& Set.of("REUSE", "REVISE").contains(t.operation())))
|
throw new DataException("只能将本次修订主文件目录中的记录转入历史");
|
}
|
for (DmsCenterActivation target : ordered) {
|
DmsFileVersionEntity current = versions.selectCurrentEffective(tenantId, target.documentId());
|
if ("RETIRE".equals(target.operation())) {
|
if (current == null || !target.fileVersionId().equals(current.getId())
|
|| !target.fileVersionId().equals(target.baseFileVersionId()))
|
throw new DataException("移除记录已不是原批准的现行版本");
|
var before = states.selectAuditState(tenantId, target.fileVersionId());
|
if (states.retireCurrent(tenantId, target.documentId(), target.fileVersionId(), actorId) != 1)
|
throw new DataException("移除记录转入历史失败");
|
recordState(tenantId, actorId, target.documentId(), target.fileVersionId(), before);
|
continue;
|
}
|
if ("REUSE".equals(target.operation())) {
|
if (current == null || !target.fileVersionId().equals(current.getId()))
|
throw new DataException("沿用版本已不是现行版本");
|
continue;
|
}
|
DmsFileVersionEntity version = versions.selectByTenantAndId(tenantId, target.fileVersionId());
|
if (version == null || !target.documentId().equals(version.getDocumentId()))
|
throw new DataException("生效版本不属于目标文档");
|
if ("REVISE".equals(target.operation())) {
|
if (current == null || !Objects.equals(target.baseFileVersionId(), current.getId()))
|
throw new DataException("修订来源版本已不是现行版本");
|
var before = states.selectAuditState(tenantId, current.getId());
|
if (states.supersedeCurrent(tenantId, target.documentId(), current.getId(),
|
version.getVersionLabel(), actorId) != 1) throw new DataException("现行版本切换失败");
|
recordState(tenantId, actorId, target.documentId(), current.getId(), before);
|
} else if (current != null) throw new DataException("新文件已存在有效版本");
|
var before = states.selectAuditState(tenantId, target.fileVersionId());
|
if (states.activateApproved(tenantId, target.fileVersionId(), actorId) != 1)
|
throw new DataException("批准文件尚未到生效日期或已失效");
|
recordState(tenantId, actorId, target.documentId(), target.fileVersionId(), before);
|
search.enqueueContentUpsert(tenantId, target.documentId(), target.fileVersionId(), target.checksumSha256());
|
}
|
}
|
|
private void recordState(String tenantId, String approvalActorId, UUID documentId, UUID versionId,
|
jnpf.dmsIntegration.audit.DmsVersionStateAuditRow before) {
|
var after = states.selectAuditState(tenantId, versionId);
|
if (before == null || after == null) throw new DataException("文件状态审计快照缺失");
|
businessAudit.record(tenantId, "DMS_VERSION_STATE_CHANGED", "文件版本效力变更",
|
"dms_version_states", versionId.toString(), state(before), state(after), after.getStatusReason(),
|
values("document_id", documentId, "file_version_id", versionId, "approval_actor_id", approvalActorId));
|
}
|
|
private Map<String, Object> state(jnpf.dmsIntegration.audit.DmsVersionStateAuditRow value) {
|
return values("lifecycle_status", value.getLifecycleStatus(), "effective_from", value.getEffectiveFrom(),
|
"effective_to", value.getEffectiveTo(), "status_reason", value.getStatusReason());
|
}
|
}
|
