package jnpf.dmsService.expiry;
|
|
import jnpf.dmsEntity.storage.expiry.DmsFileExpiryResource;
|
import jnpf.dmsMapper.DmsFileExpiryMapper;
|
import jnpf.dmsMapper.DmsFileExpiryProjectionMapper;
|
import jnpf.exception.DataException;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Propagation;
|
import org.springframework.transaction.annotation.Transactional;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.UUID;
|
|
@Service
|
@RequiredArgsConstructor
|
public class DmsFileExpiryProjection {
|
private final DmsFileExpiryProjectionMapper resources;
|
private final DmsFileExpiryMapper expiry;
|
|
/** The lifecycle caller owns the document lock and transaction, including this durable outbox. */
|
@Transactional(propagation = Propagation.MANDATORY)
|
public void apply(String tenantId, UUID versionId, Date effectiveTo, String actor) {
|
if (resources.hasPendingProjection(tenantId, versionId)) {
|
throw new DataException("批准文件尚未完成业务回写，到期结算等待原任务补偿完成");
|
}
|
List<DmsFileExpiryResource> matches = resources.lockResources(tenantId, versionId);
|
if (matches.size() > 1) throw new DataException("到期版本映射了多个当前业务资源，需人工核对");
|
if (!matches.isEmpty()) {
|
DmsFileExpiryResource resource = matches.get(0);
|
if (!versionId.toString().equals(resource.getCenterVersionId())
|
|| !versionId.toString().equals(resource.getVersionCenterId())) {
|
throw new DataException("到期版本与业务当前版本映射不一致，需人工核对");
|
}
|
if (!("effective".equals(resource.getBizStatus())
|
|| ("disabled".equals(resource.getBizStatus()) && "yidaoqi".equals(resource.getDisabledSource())))) {
|
throw new DataException("业务资源已由其他原因停用或转历史，不覆盖原状态");
|
}
|
if (resources.disable(tenantId, resource, effectiveTo, actor) != 1) {
|
throw new DataException("到期业务资源已变化，请重试");
|
}
|
if (resources.expireBusinessVersion(tenantId, resource, actor) != 1) {
|
throw new DataException("到期业务版本状态或映射已变化，请重试");
|
}
|
resources.closeRelations(tenantId, resource.getId(), effectiveTo, actor);
|
}
|
// Center-only uploads and historical versions still require index cleanup.
|
expiry.enqueueCleanup(tenantId, versionId);
|
}
|
}
|
