package jnpf.dmsService;
|
|
import jnpf.dmsBusinessOccupancy.BusinessFileExpiryGate;
|
import org.mybatis.spring.SqlSessionTemplate;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
import java.util.UUID;
|
|
/** One coordinated rollout switch. Must stay off until acquisition, completion and all consumers pass. */
|
@Component
|
public class DmsBusinessLifecycleGuard {
|
private final boolean enabled;
|
private final BusinessFileExpiryGate expiry;
|
private final jnpf.dmsBusinessOccupancy.BusinessFileExecutionService execution;
|
public DmsBusinessLifecycleGuard(SqlSessionTemplate sessions,
|
@Value("${dms.business-occupancy.enabled:false}") boolean enabled) {
|
this.enabled = enabled;
|
this.execution = enabled ? new jnpf.dmsBusinessOccupancy.BusinessFileExecutionService(sessions) : null;
|
this.expiry = enabled ? new BusinessFileExpiryGate(sessions) : null;
|
}
|
/** Native source is reconstructed by the approved audit loader; no posted subset or chain. */
|
public void requireAuditSource(jnpf.dmsEntity.storage.approval.DmsApprovedBatch source) {
|
if(!enabled) return;
|
var rows = "wailai_wenjian_xinzeng_shenhe".equals(source.getAuditType())
|
? requireExternalCreation(source)
|
: "xiuding_shenhe".equals(source.getAuditType())
|
? execution.requireRevision(source.getTenantId(),source.getAuditId())
|
: execution.requireCreation(source.getTenantId(),source.getAuditId());
|
verifySourceCoverage(rows,source.getItems());
|
}
|
private java.util.List<jnpf.dmsBusinessOccupancy.BusinessFileOccupancy> requireExternalCreation(
|
jnpf.dmsEntity.storage.approval.DmsApprovedBatch source) {
|
if (source.getItems() == null || source.getItems().size() != 1
|
|| !"CREATE".equals(source.getItems().get(0).getChangeType()))
|
throw new jnpf.exception.DataException("外来文件批准来源必须只有一份新文件");
|
return execution.requireExternalCreation(source.getTenantId(), source.getAuditId(),
|
source.getTaskId(), source.getItems().get(0).getDocumentNo());
|
}
|
/** Exact one-to-one match before center registration/activation; caller already verified receipts. */
|
public static void verifySourceCoverage(java.util.List<jnpf.dmsBusinessOccupancy.BusinessFileOccupancy> businessReceipts,
|
java.util.List<jnpf.dmsEntity.storage.approval.DmsApprovedItem> items) {
|
var numbers=new java.util.HashSet<String>();
|
for(var item:items) {
|
var matching=businessReceipts.stream().filter(row->"CREATE".equals(item.getChangeType())
|
? "CREATE".equals(row.getOperation()) && java.util.Objects.equals(item.getDocumentNo(),row.getFileNumber())
|
: item.getBaseFileVersionId()!=null && java.util.Objects.equals(item.getBaseFileVersionId().toString(),row.getCenterVersionId()))
|
.toList();
|
if(matching.size()!=1 || !numbers.add(matching.get(0).getFileNumber()))
|
throw new jnpf.exception.DataException("审核来源没有唯一匹配的业务占用");
|
}
|
if(numbers.size()!=businessReceipts.size()) throw new jnpf.exception.DataException("审核来源与业务占用集合不一致");
|
}
|
public boolean isEnabled() { return enabled; }
|
public void guardStandaloneActivation(String tenant,UUID versionId) {
|
if(enabled) execution.guardStandaloneActivation(tenant,versionId.toString());
|
}
|
public void guardStandaloneRegistration(String tenant,String fileNumber) {
|
if(enabled) execution.guardStandaloneRegistration(tenant,fileNumber);
|
}
|
public java.util.List<jnpf.dmsBusinessOccupancy.BusinessFileOccupancy> requireCurrentUserExtension(
|
String task,String application,java.util.Collection<String> fileIds) {
|
if(!enabled) return java.util.List.of();
|
String tenant=jnpf.util.UserProvider.getUser().getTenantId();
|
return execution.requireExtension(tenant==null || tenant.isBlank() ? "0" : tenant,application,task,fileIds);
|
}
|
public java.util.List<jnpf.dmsBusinessOccupancy.BusinessFileOccupancy> requireCurrentUserExecution(
|
String task,String application,String operation,java.util.Collection<String> fileIds) {
|
if(!enabled) return java.util.List.of();
|
String tenant=jnpf.util.UserProvider.getUser().getTenantId();
|
return execution.require(tenant==null || tenant.isBlank() ? "0" : tenant,task,application,task,operation,fileIds);
|
}
|
public java.util.List<jnpf.dmsBusinessOccupancy.BusinessFileOccupancy> requireExecution(
|
String tenant,String task,String application,String operation,java.util.Collection<String> fileIds) {
|
return enabled ? execution.require(tenant,task,application,task,operation,fileIds) : java.util.List.of();
|
}
|
public java.util.List<jnpf.dmsBusinessOccupancy.BusinessFileOccupancy> requireRevision(String tenant,String auditId) {
|
return enabled ? execution.requireRevision(tenant,auditId) : java.util.List.of();
|
}
|
public java.util.List<jnpf.dmsBusinessOccupancy.BusinessFileOccupancy> requireCreation(String tenant,String auditId) {
|
return enabled ? execution.requireCreation(tenant,auditId) : java.util.List.of();
|
}
|
public java.util.List<jnpf.dmsBusinessOccupancy.BusinessFileOccupancy> requireExternalCreation(
|
String tenant, String auditId, String taskId, String fileNumber) {
|
return enabled ? execution.requireExternalCreation(tenant, auditId, taskId, fileNumber) : java.util.List.of();
|
}
|
public void guardValidity(String tenant,String task,java.util.Collection<String> versions) {
|
if(enabled) execution.guardValidity(tenant,task,versions);
|
}
|
public void guardNumbers(String tenant,String chain,java.util.Collection<String> numbers) {
|
if(enabled) execution.guardNumbers(tenant,chain,numbers);
|
}
|
public void guardVersions(String tenant,String chain,java.util.Collection<String> versions) {
|
if(enabled) execution.guardVersions(tenant,chain,versions);
|
}
|
public void completeExecution(java.util.List<jnpf.dmsBusinessOccupancy.BusinessFileOccupancy> receipts) {
|
if(enabled) execution.complete(receipts);
|
}
|
public java.util.List<jnpf.dmsBusinessOccupancy.BusinessFileOccupancy> terminationCandidates(String afterId,int limit) {
|
return enabled ? execution.terminationCandidates(afterId,limit) : java.util.List.of();
|
}
|
@org.springframework.transaction.annotation.Transactional(rollbackFor=Exception.class)
|
public boolean releaseEnded(jnpf.dmsBusinessOccupancy.BusinessFileOccupancy candidate) {
|
return enabled && execution.releaseEnded(candidate);
|
}
|
public boolean tryEnterExpiry(String tenantId, UUID centerVersionId) {
|
return !enabled || expiry.tryEnter(tenantId, centerVersionId.toString());
|
}
|
}
|
