package jnpf.dmsService;
|
|
import jnpf.dmsEntity.permission.entity.DmsDocumentEntity;
|
import jnpf.dmsEntity.permission.entity.DmsFileVersionEntity;
|
import jnpf.dmsEntity.storage.DmsWorkflowSourceKey;
|
import jnpf.dmsEntity.storage.enums.DmsWorkflowFileType;
|
import jnpf.dmsEntity.storage.vo.DmsFileUploadVO;
|
import jnpf.dmsIntegration.audit.DmsVersionStateAuditRow;
|
import jnpf.dmsMapper.DmsDocumentMapper;
|
import jnpf.dmsMapper.DmsFileObjectMapper;
|
import jnpf.dmsMapper.DmsFileVersionMapper;
|
import jnpf.dmsMapper.DmsVersionStateMapper;
|
import jnpf.dmsPermission.DmsPermissionError;
|
import jnpf.dmsPermission.DmsPermissionException;
|
import jnpf.dmsService.search.DmsSearchIndexJobService;
|
import jnpf.exception.DataException;
|
import jnpf.flowable.WorkFlowApi;
|
import jnpf.flowable.entity.TaskEntity;
|
import jnpf.flowable.enums.TaskStatusEnum;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.Objects;
|
|
@Service
|
@RequiredArgsConstructor
|
public class DmsWorkflowFileActivationService {
|
private static final String SERVICE_ID = "jnpf-file";
|
|
private final WorkFlowApi workFlowApi;
|
private final DmsFileObjectMapper fileObjectMapper;
|
private final DmsDocumentMapper documentMapper;
|
private final DmsFileVersionMapper fileVersionMapper;
|
private final DmsVersionStateMapper versionStateMapper;
|
private final DmsSearchIndexJobService searchIndexJobService;
|
private final DmsBusinessLifecycleGuard businessOccupancy;
|
|
@Transactional(rollbackFor = Exception.class)
|
public DmsFileUploadVO activate(String tenantId, String flowId, String taskId,
|
DmsWorkflowFileType fileType, String approvedBy) {
|
TaskEntity task = requireTask(flowId, taskId);
|
if (!TaskStatusEnum.PASSED.getCode().equals(task.getStatus())) {
|
throw new DataException("流程任务尚未审核通过，不能激活文件");
|
}
|
return activateVerified(tenantId, flowId, taskId, fileType, approvedBy);
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
public DmsFileUploadVO activateVerified(String tenantId, String flowId, String taskId,
|
DmsWorkflowFileType fileType, String approvedBy) {
|
String activationActor = actor(approvedBy);
|
String sourceKey = DmsWorkflowSourceKey.of(flowId, taskId, fileType);
|
DmsFileUploadVO staged = fileObjectMapper.selectUploadBySource(tenantId, SERVICE_ID, sourceKey);
|
if (staged == null || staged.getFileVersionId() == null || staged.getDocumentId() == null) {
|
throw new DataException("未找到当前流程任务暂存的文件");
|
}
|
// Number lock precedes center row locks; no caller task ID can exempt a business chain.
|
businessOccupancy.guardStandaloneActivation(tenantId,staged.getFileVersionId());
|
DmsDocumentEntity document = documentMapper.selectByTenantAndIdForUpdate(
|
tenantId, staged.getDocumentId());
|
if (document == null) {
|
throw DmsPermissionException.of(DmsPermissionError.RESOURCE_NOT_FOUND, "暂存文件不存在");
|
}
|
DmsVersionStateAuditRow state = versionStateMapper.selectAuditState(
|
tenantId, staged.getFileVersionId());
|
if (state != null && "EFFECTIVE".equals(state.getLifecycleStatus())) {
|
staged.setLifecycleStatus("EFFECTIVE");
|
return staged;
|
}
|
if (state == null || !"PENDING_APPROVAL".equals(state.getLifecycleStatus())) {
|
throw new DataException("暂存文件状态不允许激活");
|
}
|
|
if (fileType == DmsWorkflowFileType.REVISE) {
|
DmsFileVersionEntity current = fileVersionMapper.selectCurrentEffective(
|
tenantId, staged.getDocumentId());
|
if (current == null || !Objects.equals(current.getId(), staged.getBaseFileVersionId())) {
|
throw DmsPermissionException.of(DmsPermissionError.REVISION_CONFLICT,
|
"待修订版本已不是现行有效版本，请重新发起审批");
|
}
|
int superseded = versionStateMapper.supersedeCurrent(tenantId, staged.getDocumentId(),
|
current.getId(), staged.getVersionLabel(), activationActor);
|
if (superseded != 1) {
|
throw DmsPermissionException.of(DmsPermissionError.REVISION_CONFLICT,
|
"现行有效版本已发生变化，请重试");
|
}
|
} else if (fileVersionMapper.selectCurrentEffective(tenantId, staged.getDocumentId()) != null) {
|
throw new DataException("新增文件已经存在有效版本");
|
}
|
|
if (versionStateMapper.activateWorkflowPending(
|
tenantId, staged.getFileVersionId(), flowId, taskId, fileType.name(),
|
activationActor) != 1) {
|
throw new DataException("工作流文件激活失败，请重试");
|
}
|
searchIndexJobService.enqueueContentUpsert(tenantId, staged.getDocumentId(),
|
staged.getFileVersionId(), staged.getChecksumSha256());
|
staged.setLifecycleStatus("EFFECTIVE");
|
return staged;
|
}
|
|
TaskEntity requireTask(String flowId, String taskId) {
|
TaskEntity task = workFlowApi.getInfoSubmit(taskId);
|
if (task == null || !taskId.equals(task.getId())) {
|
throw new DataException("未找到与taskId匹配的流程任务");
|
}
|
if (!flowId.equals(task.getFlowId()) && !flowId.equals(task.getTemplateId())) {
|
throw new DataException("流程任务不属于指定flowID");
|
}
|
return task;
|
}
|
|
private String actor(String value) {
|
return value == null || value.trim().isEmpty() ? "dms-workflow-activation" : value.trim();
|
}
|
}
|
