package jnpf.dmsService.center;
|
|
import jnpf.base.UserInfo;
|
import jnpf.dmsEntity.storage.form.DmsFileUploadRegisterForm;
|
import jnpf.dmsEntity.storage.form.DmsFileRevisionRegisterForm;
|
import jnpf.dmsEntity.storage.vo.DmsFileUploadVO;
|
import jnpf.dmsMapper.DmsVersionStateMapper;
|
import jnpf.dmsService.DmsFileUploadService;
|
import jnpf.dmsService.DmsFileRevisionService;
|
import jnpf.exception.DataException;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import java.util.Date;
|
import java.util.UUID;
|
|
/** Trusted in-module center entry; the caller supplies verified approval facts, never a form to look up. */
|
@Service
|
@RequiredArgsConstructor
|
public class DmsCenterRegistrationService {
|
private final DmsFileUploadService uploads;
|
private final DmsFileRevisionService revisions;
|
private final DmsVersionStateMapper states;
|
|
@Transactional(rollbackFor = Exception.class)
|
public DmsFileUploadVO register(DmsFileUploadRegisterForm content, UUID baseVersionId,
|
String revisionReason, String flowReference, String taskReference, UserInfo actor,
|
Date approvedAt, Date scheduledAt, Date effectiveTo) {
|
if (actor == null || actor.getTenantId() == null || actor.getUserId() == null
|
|| approvedAt == null || scheduledAt == null)
|
throw new DataException("中心登记缺少已验证的操作人或批准日期");
|
// Retain the existing source namespace for idempotency of previously registered files.
|
DmsFileUploadVO result;
|
if (baseVersionId == null) {
|
result = uploads.registerApproved(content, "jnpf-file", flowReference, taskReference, actor);
|
} else {
|
DmsFileRevisionRegisterForm revision = new DmsFileRevisionRegisterForm();
|
BeanUtils.copyProperties(content, revision);
|
revision.setBaseFileVersionId(baseVersionId);
|
revision.setRevisionReason(revisionReason);
|
result = revisions.registerApproved(revision, "jnpf-file", flowReference, taskReference, actor);
|
}
|
if (result == null || !content.getDocumentId().equals(result.getDocumentId())
|
|| !content.getFileVersionId().equals(result.getFileVersionId())
|
|| !content.getChecksumSha256().equals(result.getChecksumSha256()))
|
throw new DataException("中心登记结果与请求不一致");
|
if (states.approvePending(actor.getTenantId(), content.getFileVersionId(), approvedAt,
|
scheduledAt, effectiveTo, actor.getUserId()) != 1)
|
throw new DataException("文件登记批准事实失败");
|
return result;
|
}
|
}
|
