package jnpf.dmsService;
|
|
import com.fasterxml.jackson.databind.JsonNode;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import jnpf.dmsEntity.DmsWenjianBanbenEntity;
|
import jnpf.dmsEntity.DmsWenjianXinzengShenheEntity;
|
import jnpf.dmsEntity.DmsWenjianXiudingShenheEntity;
|
import jnpf.dmsEntity.DmsWenjianXiudingShenqingZixiangEntity;
|
import jnpf.dmsEntity.storage.form.DmsWorkflowFilePrepareForm;
|
import jnpf.dmsEntity.storage.DmsWorkflowSourceKey;
|
import jnpf.dmsEntity.storage.enums.DmsWorkflowFileType;
|
import jnpf.dmsEntity.storage.vo.DmsFileUploadVO;
|
import jnpf.dmsMapper.DmsFileObjectMapper;
|
import jnpf.dmsMapper.DmsWenjianXinzengShenheMapper;
|
import jnpf.dmsMapper.DmsWenjianXiudingShenheMapper;
|
import jnpf.dmsMapper.DmsWenjianBanbenMapper;
|
import jnpf.dmsMapper.DmsWenjianXiudingShenqingZixiangMapper;
|
import jnpf.exception.DataException;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Component;
|
|
import java.net.URI;
|
import java.util.UUID;
|
|
@Component
|
@RequiredArgsConstructor
|
public class DmsWorkflowApprovalValidator {
|
private final ObjectMapper objectMapper;
|
private final DmsWenjianBanbenMapper businessVersionMapper;
|
private final DmsWenjianXiudingShenqingZixiangMapper revisionDetailMapper;
|
private final DmsFileObjectMapper fileObjectMapper;
|
private final DmsWenjianXinzengShenheMapper newAuditMapper;
|
private final DmsWenjianXiudingShenheMapper revisionAuditMapper;
|
|
public String validateNew(DmsWenjianXinzengShenheEntity audit,
|
DmsWorkflowFilePrepareForm form) {
|
requireEqual(audit.getWenjianBianhao(), form.getDocumentNo(), "文件编号");
|
requireEqual(audit.getWenjianMingcheng(), form.getDocumentName(), "文件名称");
|
requireEqual(audit.getWenjianMuluId(), form.getFolderId() == null ? null : form.getFolderId().toString(), "文件目录");
|
requireEqual(audit.getGuishuBumenId(), form.getResponsibleDeptId(), "归属部门");
|
return approvedFile(audit.getWenjian(), form.getUrl());
|
}
|
|
public String validateRevision(String tenantId, DmsWenjianXiudingShenheEntity audit,
|
DmsWorkflowFilePrepareForm form) {
|
requireEqual(audit.getWenjianMingcheng(), form.getDocumentName(), "文件名称");
|
requireEqual(audit.getWenjianMuluId(), form.getFolderId() == null ? null : form.getFolderId().toString(), "文件目录");
|
requireEqual(audit.getGuishuBumenId(), form.getResponsibleDeptId(), "归属部门");
|
String businessVersionId = audit.getYuanWenjianBanbenId();
|
String businessFileId = audit.getWenjianId();
|
if (audit.getXiudingShenqingZixiangId() != null) {
|
DmsWenjianXiudingShenqingZixiangEntity detail = revisionDetailMapper.selectByIdForUpdate(
|
tenantId, audit.getXiudingShenqingZixiangId());
|
if (detail == null) {
|
throw new DataException("修订审核单关联的申请子项不存在");
|
}
|
businessVersionId = detail.getYuanWenjianBanbenId();
|
businessFileId = detail.getWenjianId();
|
}
|
if (businessVersionId == null || businessFileId == null) {
|
throw new DataException("修订审核单缺少批准的原文件版本");
|
}
|
DmsWenjianBanbenEntity version = businessVersionMapper.selectById(tenantId, businessVersionId);
|
if (version == null || !businessFileId.equals(version.getWenjianId())) {
|
throw new DataException("修订审核单关联的业务文件版本不存在或不匹配");
|
}
|
// 业务版本ID与文件中心UUID不是同一套ID，必须通过已有映射核对。
|
try {
|
if (form.getVersionId() == null || !form.getVersionId().equals(fileCenterVersion(tenantId, version))) {
|
throw new DataException("versionId与审核批准的文件中心版本不一致");
|
}
|
} catch (IllegalArgumentException | NullPointerException exception) {
|
throw new DataException("审核批准的原版本尚未关联有效的文件中心版本");
|
}
|
return approvedFile(audit.getWenjian(), form.getUrl());
|
}
|
|
private UUID fileCenterVersion(String tenantId, DmsWenjianBanbenEntity version) {
|
if (version.getWenjianZhongxinBanbenId() != null) {
|
return UUID.fromString(version.getWenjianZhongxinBanbenId());
|
}
|
// 兼容尚未回写映射的业务版本，只从其来源审核单的任务登记解析，不能信任请求UUID。
|
if (version.getLaiyuanDanjuId() == null || version.getLaiyuanZixiangId() != null) {
|
throw new DataException("审核批准的原版本尚未关联文件中心版本");
|
}
|
String key = null;
|
if ("xinzeng_shenhe".equals(version.getLaiyuanDanjuLeixing())) {
|
DmsWenjianXinzengShenheEntity source = newAuditMapper.selectOne(
|
new LambdaQueryWrapper<DmsWenjianXinzengShenheEntity>()
|
.eq(DmsWenjianXinzengShenheEntity::getTenantId, tenantId)
|
.eq(DmsWenjianXinzengShenheEntity::getId, version.getLaiyuanDanjuId())
|
.isNull(DmsWenjianXinzengShenheEntity::getDeleteMark));
|
if (source != null) {
|
key = DmsWorkflowSourceKey.of(source.getFlowId(), source.getFlowTaskId(), DmsWorkflowFileType.CREATE);
|
}
|
} else if ("xiuding_shenhe".equals(version.getLaiyuanDanjuLeixing())) {
|
DmsWenjianXiudingShenheEntity source = revisionAuditMapper.selectOne(
|
new LambdaQueryWrapper<DmsWenjianXiudingShenheEntity>()
|
.eq(DmsWenjianXiudingShenheEntity::getTenantId, tenantId)
|
.eq(DmsWenjianXiudingShenheEntity::getId, version.getLaiyuanDanjuId())
|
.isNull(DmsWenjianXiudingShenheEntity::getDeleteMark));
|
if (source != null) {
|
key = DmsWorkflowSourceKey.of(source.getFlowId(), source.getFlowTaskId(), DmsWorkflowFileType.REVISE);
|
}
|
}
|
DmsFileUploadVO registered = key == null ? null
|
: fileObjectMapper.selectUploadBySource(tenantId, "jnpf-file", key);
|
if (registered == null || registered.getFileVersionId() == null) {
|
throw new DataException("审核批准的原版本尚未登记到文件中心");
|
}
|
return registered.getFileVersionId();
|
}
|
|
private void requireEqual(String approved, String requested, String label) {
|
if (approved == null || approved.trim().isEmpty() || requested == null
|
|| !approved.trim().equals(requested.trim())) {
|
throw new DataException(label + "与审核批准的内容不一致");
|
}
|
}
|
|
String approvedFile(String json, String url) {
|
try {
|
JsonNode root = objectMapper.readTree(json);
|
JsonNode file = findFile(root, filePath(url));
|
if (file == null) {
|
throw new DataException("文件URL不在审核批准的附件中");
|
}
|
return objectMapper.writeValueAsString(file);
|
} catch (DataException exception) {
|
throw exception;
|
} catch (Exception exception) {
|
throw new DataException("审核单附件信息无效，无法验证批准的文件");
|
}
|
}
|
|
private JsonNode findFile(JsonNode node, String path) {
|
if (node == null) {
|
return null;
|
}
|
if (node.isObject() && node.path("url").isTextual()) {
|
if (path.equals(filePath(node.get("url").asText()))) {
|
return node;
|
}
|
}
|
if (node.isContainerNode()) {
|
for (JsonNode child : node) {
|
JsonNode found = findFile(child, path);
|
if (found != null) {
|
return found;
|
}
|
}
|
}
|
return null;
|
}
|
|
private String filePath(String url) {
|
URI uri = URI.create(url.trim());
|
if (uri.getScheme() != null && !"http".equalsIgnoreCase(uri.getScheme())
|
&& !"https".equalsIgnoreCase(uri.getScheme())) {
|
throw new DataException("审核附件不是公共文件路径");
|
}
|
String path = uri.getPath();
|
String prefix = "/api/file/Image/";
|
int start = path == null ? -1 : path.indexOf(prefix);
|
if (start < 0) {
|
throw new DataException("审核附件不是公共文件路径");
|
}
|
String suffix = path.substring(start + prefix.length());
|
String[] parts = suffix.split("/", -1);
|
if (parts.length != 2) {
|
throw new DataException("审核附件路径格式不正确");
|
}
|
for (String part : parts) {
|
if (part.isBlank() || part.contains("\\") || ".".equals(part) || "..".equals(part)) {
|
throw new DataException("审核附件路径格式不正确");
|
}
|
}
|
return suffix;
|
}
|
}
|
