package jnpf.dmsService;
|
|
import jnpf.audit.sdk.annotation.AuditLog;
|
import jnpf.dmsEntity.permission.entity.DmsFileVersionEntity;
|
import jnpf.dmsEntity.storage.form.DmsFileLifecycleUpdateForm;
|
import jnpf.dmsEntity.storage.vo.DmsFileLifecycleUpdateVO;
|
import jnpf.dmsIntegration.audit.DmsVersionStateAuditRow;
|
import jnpf.dmsMapper.DmsDocumentMapper;
|
import jnpf.dmsMapper.DmsFileVersionMapper;
|
import jnpf.dmsMapper.DmsVersionStateMapper;
|
import jnpf.exception.DataException;
|
import jnpf.dmsService.expiry.DmsFileExpiryProjection;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.Date;
|
import java.util.UUID;
|
|
@Service
|
@RequiredArgsConstructor
|
public class DmsFileLifecycleService {
|
private static final String EFFECTIVE = "EFFECTIVE";
|
private static final String EXPIRED = "EXPIRED";
|
private static final String DEFAULT_EXPIRED_REASON = "文件有效期已到，生命周期自动转为已过期";
|
|
private final DmsFileVersionMapper fileVersionMapper;
|
private final DmsDocumentMapper documentMapper;
|
private final DmsVersionStateMapper versionStateMapper;
|
private final DmsFileExpiryProjection projection;
|
private final DmsBusinessLifecycleGuard businessOccupancy;
|
|
@Transactional(rollbackFor = Exception.class)
|
@AuditLog(action = "UPDATE", label = "同步文件到期状态", bizModule = "DMS",
|
bizType = "DMS_FILE_VERSION", bizCodeExpr = "", bizCodeRequired = false,
|
targetTable = "dms_version_states", targetIdExpr = "#p0.fileVersionId",
|
extraExpr = "{'tenantId': #p0.tenantId, 'lifecycleStatus': #p0.lifecycleStatus, "
|
+ "'effectiveFrom': #p0.effectiveFrom, 'effectiveTo': #p0.effectiveTo}")
|
public DmsFileLifecycleUpdateVO updateExpired(DmsFileLifecycleUpdateForm form,
|
String serviceId) {
|
if (form == null || form.getTenantId() == null || form.getTenantId().isBlank()
|
|| form.getFileVersionId() == null || form.getLifecycleStatus() == null
|
|| serviceId == null || serviceId.isBlank()) {
|
throw new DataException("到期同步缺少租户、版本、状态或操作来源");
|
}
|
String tenantId = form.getTenantId().trim();
|
String lifecycleStatus = form.getLifecycleStatus().trim();
|
if (!EXPIRED.equals(lifecycleStatus)) throw new DataException("到期同步仅支持EXPIRED状态");
|
|
if (!businessOccupancy.tryEnterExpiry(tenantId, form.getFileVersionId()))
|
throw new DataException("文件业务占用或版本映射尚未释放，到期同步等待后重试");
|
|
DmsFileVersionEntity version = fileVersionMapper.selectByTenantAndId(
|
tenantId, form.getFileVersionId());
|
if (version == null) {
|
throw new DataException("文件版本不存在：" + form.getFileVersionId());
|
}
|
if (documentMapper.selectByTenantAndIdForUpdate(tenantId, version.getDocumentId()) == null) {
|
throw new DataException("文件所属文档不存在：" + version.getDocumentId());
|
}
|
|
DmsVersionStateAuditRow state = versionStateMapper.selectAuditState(
|
tenantId, form.getFileVersionId());
|
if (state == null) {
|
throw new DataException("文件生命周期状态不存在：" + form.getFileVersionId());
|
}
|
Date effectiveFrom = state.getEffectiveFrom();
|
Date effectiveTo = state.getEffectiveTo();
|
if (effectiveFrom == null || effectiveTo == null || !effectiveTo.after(effectiveFrom)) {
|
throw new DataException("中心未登记合法的有限有效期，不能自动过期");
|
}
|
if (form.getEffectiveTo() != null && !sameInstant(effectiveTo, form.getEffectiveTo())) {
|
throw new DataException("到期请求与中心已登记有效期不一致，请重新读取后重试");
|
}
|
if (EXPIRED.equals(state.getLifecycleStatus())) {
|
projection.apply(tenantId, form.getFileVersionId(), effectiveTo, serviceId);
|
return result(form.getFileVersionId(), effectiveFrom, effectiveTo);
|
}
|
if (!EFFECTIVE.equals(state.getLifecycleStatus())) {
|
throw new DataException("文件当前生命周期状态不允许转为EXPIRED：" + state.getLifecycleStatus());
|
}
|
|
String reason = trimToNull(form.getStatusReason());
|
int updated = versionStateMapper.expire(
|
tenantId, form.getFileVersionId(),
|
reason == null ? DEFAULT_EXPIRED_REASON : reason, serviceId);
|
if (updated != 1) {
|
throw new DataException("文件到期状态同步失败，请重试：" + form.getFileVersionId());
|
}
|
projection.apply(tenantId, form.getFileVersionId(), state.getEffectiveTo(), serviceId);
|
return result(form.getFileVersionId(), effectiveFrom, effectiveTo);
|
}
|
|
private DmsFileLifecycleUpdateVO result(UUID fileVersionId, Date effectiveFrom,
|
Date effectiveTo) {
|
DmsFileLifecycleUpdateVO result = new DmsFileLifecycleUpdateVO();
|
result.setFileVersionId(fileVersionId);
|
result.setLifecycleStatus(EXPIRED);
|
result.setEffectiveFrom(effectiveFrom);
|
result.setEffectiveTo(effectiveTo);
|
return result;
|
}
|
|
private boolean sameInstant(Date first, Date second) {
|
return first != null && second != null && first.getTime() == second.getTime();
|
}
|
|
private String trimToNull(String value) {
|
return value == null || value.trim().isEmpty() ? null : value.trim();
|
}
|
}
|
