package jnpf.dmsService;
|
|
import jnpf.dmsEntity.storage.*;
|
import jnpf.dmsMapper.DmsRevisionEditMapper;
|
import jnpf.exception.DataException;
|
import jnpf.util.JsonUtil;
|
import jnpf.util.TicketUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import java.util.function.Function;
|
import java.util.function.BiFunction;
|
import org.springframework.stereotype.Service;
|
import java.util.*;
|
|
/** 核验本人有效修订来源，供原生保存与副本编辑使用，不修改原版本或业务单据。 */
|
@Service
|
public class DmsRevisionEditService {
|
private static final com.fasterxml.jackson.databind.ObjectMapper SOURCE_JSON = new com.fasterxml.jackson.databind.ObjectMapper();
|
private final DmsRevisionEditMapper mapper;
|
private final Function<String,String> parseTicket;
|
private final BiFunction<String,Long,String> issueTicket;
|
@Autowired
|
public DmsRevisionEditService(DmsRevisionEditMapper mapper) {
|
this(mapper, TicketUtil::parseTicket, TicketUtil::createTicket);
|
}
|
DmsRevisionEditService(DmsRevisionEditMapper mapper, Function<String,String> parseTicket,
|
BiFunction<String,Long,String> issueTicket) {
|
this.mapper = mapper; this.parseTicket = parseTicket; this.issueTicket = issueTicket;
|
}
|
public List<Map<String,Object>> prepare(DmsRevisionEditRequest request, String tenant, String owner) {
|
List<DmsRevisionEditSource> sources=mapper.sources(tenant, owner, request.getSourceItemId(), request.getModelId());
|
if (sources.isEmpty()) throw denied();
|
List<Map<String,Object>> result=new ArrayList<>();
|
for (DmsRevisionEditSource source:sources) {
|
List<Map<String,Object>> files=new ArrayList<>();
|
for (Map<String,Object> original:files(source.getFiles())) {
|
Map<String,Object> file=canonical(original);
|
if ("wenjian".equals(source.getField()) && Objects.toString(source.getParentField(), "").isEmpty()
|
&& original.get("laiyuan_muban_id") instanceof String
|
&& !((String) original.get("laiyuan_muban_id")).isBlank())
|
file.put("laiyuan_muban_id", original.get("laiyuan_muban_id"));
|
// 来源凭据也用于原生暂存，不能只覆盖可在线编辑的 DOC/DOCX。
|
if (hasFileId(file)) {
|
Map<String,Object> proof=new LinkedHashMap<>();
|
proof.put("purpose","dms-revision-edit"); proof.put("tenantId",tenant); proof.put("ownerId",owner);
|
proof.put("modelId",request.getModelId()); proof.put("sourceItemId",request.getSourceItemId());
|
proof.put("parentField",source.getParentField()); proof.put("field",source.getField());
|
proof.put("versionId",source.getVersionId()); proof.put("originFileId",file.get("fileId"));
|
proof.put("expiresAt",System.currentTimeMillis()+14400000L); proof.put("file",new LinkedHashMap<>(file));
|
file.put("revisionEditReceipt",issueTicket.apply(JsonUtil.getObjectToString(proof),14400L));
|
}
|
files.add(file);
|
}
|
Map<String,Object> row=new LinkedHashMap<>();
|
row.put("versionId",source.getVersionId()); row.put("parentField",source.getParentField());
|
row.put("field",source.getField()); row.put("files",files); result.add(row);
|
}
|
return result;
|
}
|
public Map<String,Object> verify(DmsRevisionEditRequest request) {
|
String raw=request.getReceipt()==null?null:parseTicket.apply(request.getReceipt());
|
Map<String,Object> proof=raw==null?Collections.emptyMap():JsonUtil.getJsonToBean(raw,Map.class);
|
if (!"dms-revision-edit".equals(proof.get("purpose")) || !Objects.equals(request.getTenantId(),proof.get("tenantId"))
|
|| !Objects.equals(request.getOwnerId(),proof.get("ownerId")) || !Objects.equals(request.getModelId(),proof.get("modelId"))
|
|| !Objects.equals(request.getField(),proof.get("field"))
|
|| !Objects.toString(request.getParentField(),"").equals(Objects.toString(proof.get("parentField"),""))
|
|| !(proof.get("expiresAt") instanceof Number) || ((Number)proof.get("expiresAt")).longValue()<=System.currentTimeMillis()
|
|| !(proof.get("file") instanceof Map) || !hasFileId((Map<String,Object>)proof.get("file"))) throw denied();
|
Map<String,Object> original=mapper.sources(request.getTenantId(),request.getOwnerId(),Objects.toString(proof.get("sourceItemId"),""),request.getModelId())
|
.stream().filter(source -> Objects.equals(source.getVersionId(),proof.get("versionId"))
|
&& Objects.equals(source.getField(),proof.get("field")) && Objects.equals(source.getParentField(),proof.get("parentField"))
|
).flatMap(source -> files(source.getFiles()).stream())
|
.filter(file -> Objects.equals(file.get("fileId"),proof.get("originFileId"))).findFirst().orElse(null);
|
if (original == null) throw denied();
|
// 历史来源凭据不代表模板。未编辑附件保留数据库原值，不能用五字段副本覆盖沿用数据。
|
// 使用 JSON 文本跨服务携带，避免空属性（如 fileVersionId:null）被响应序列化省略。
|
proof.remove("sourceFileJson");
|
if (Objects.equals(((Map<?,?>)proof.get("file")).get("fileId"), proof.get("originFileId"))) {
|
try { proof.put("sourceFileJson", SOURCE_JSON.writeValueAsString(original)); }
|
catch (com.fasterxml.jackson.core.JsonProcessingException e) { throw denied(); }
|
}
|
return proof;
|
}
|
private static boolean hasFileId(Map<String,Object> file) {
|
return file.get("fileId") instanceof String && !((String)file.get("fileId")).isBlank();
|
}
|
private static Map<String,Object> canonical(Map<String,Object> original) {
|
Map<String,Object> result=new LinkedHashMap<>();
|
for(String key:List.of("fileId","name","fileSize","fileExtension","url")) result.put(key,original.get(key));
|
return result;
|
}
|
private static List<Map<String,Object>> files(String json) {
|
if (json==null || json.isBlank()) return Collections.emptyList();
|
return (List)JsonUtil.getJsonToList(json,Map.class);
|
}
|
private static DataException denied() { return new DataException("修订来源已失效或不属于本人，请重新选择有效的修订申请"); }
|
}
|
