package jnpf.base.service;
|
|
import cn.hutool.core.util.IdUtil;
|
import cn.hutool.crypto.digest.DigestUtil;
|
import jnpf.base.UserInfo;
|
import jnpf.base.model.uploadedit.*;
|
import jnpf.exception.DataException;
|
import jnpf.util.JsonUtil;
|
import jnpf.util.TicketUtil;
|
import jnpf.util.UserProvider;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.data.redis.core.StringRedisTemplate;
|
import org.springframework.stereotype.Service;
|
import java.util.*;
|
import java.util.concurrent.TimeUnit;
|
|
/** 无稳定业务 ID 时仅保存短期打开凭据；回调不写内容、不替换表单附件、不提供恢复。 */
|
@Service
|
@RequiredArgsConstructor
|
public class UploadEditTemporaryService {
|
private final UploadEditAccess access;
|
private final DmsAuditTemporaryEditService revisionService;
|
private final StringRedisTemplate redis;
|
|
public void prepareRevisionSave(jnpf.base.model.flow.DataModel model) {
|
revisionService.prepareSave(model);
|
}
|
|
public Map<String, Object> begin(UploadEditCommand command) {
|
if (command.getFiles() != null && command.getFiles().size() == 1
|
&& command.getFiles().get(0).containsKey("revisionEditReceipt")) return revisionService.begin(command);
|
UploadEditContext context = command.getContext();
|
if (context == null || (context.getRecordId() != null && !context.getRecordId().isEmpty()
|
&& (context.getParentField() == null || context.getParentField().isEmpty() || (context.getRowId() != null && !context.getRowId().isEmpty())))) {
|
throw new DataException("有跟踪 ID 的附件应使用工作稿编辑");
|
}
|
UserInfo user = UserProvider.getUser();
|
access.authorizeTemporary(context, user.getUserId());
|
if (command.getFiles() == null || command.getFiles().size() != 1) throw new DataException("请选择一个新上传的文件");
|
Map<String, Object> requested = command.getFiles().get(0);
|
String proofJson = requested.get("uploadReceipt") instanceof String ? TicketUtil.parseTicket((String) requested.get("uploadReceipt")) : null;
|
Map<?, ?> proof = proofJson == null ? Collections.emptyMap() : JsonUtil.getJsonToBean(proofJson, Map.class);
|
String tenant = UploadEditDraftService.tenant(user);
|
if (!"upload-edit-source".equals(proof.get("purpose")) || !tenant.equals(proof.get("tenantId"))
|
|| !user.getUserId().equals(proof.get("ownerId")) || !Objects.equals(command.getFileId(), proof.get("fileId"))
|
|| !jnpf.base.util.UploadEditStateMachine.supportsEditing(proof.get("name"))) {
|
throw new DataException("临时编辑仅支持本次新上传且归属可核验的 DOC、DOCX，请重新上传");
|
}
|
Map<String, Object> file = new LinkedHashMap<>();
|
for (String key : Arrays.asList("fileId", "name", "fileSize", "fileExtension", "url", "contentSavedAt")) file.put(key, proof.get(key));
|
jnpf.base.util.UploadTemplateSource.inherit(file, proof);
|
if (access.isDmsAuditTemporary(context)) return revisionService.beginUpload(command, file);
|
UploadEditLease lease = new UploadEditLease();
|
lease.setLeaseId(IdUtil.simpleUUID()); lease.setDraftId(lease.getLeaseId());
|
lease.setTenantId(tenant); lease.setOwnerId(user.getUserId()); lease.setTracked(false); lease.setFile(file);
|
Map<String, Object> state = new LinkedHashMap<>();
|
state.put("lease", lease); state.put("context", context);
|
redis.opsForValue().set(key(tenant, lease.getLeaseId()), JsonUtil.getObjectToString(state), 4, TimeUnit.HOURS);
|
Map<String, Object> result = new LinkedHashMap<>();
|
result.put("leaseId", lease.getLeaseId()); result.put("draftId", lease.getDraftId());
|
result.put("source", file); result.put("files", Collections.singletonList(file)); result.put("revision", 0);
|
result.put("canDiscard", false);
|
return result;
|
}
|
|
/** 状态轮询不授予文件访问权；保留 Redis 到期/清理和租约归属检查。 */
|
public boolean canReadStatus(String tenant, String owner, String leaseId) {
|
if (revisionService.canReadStatus(tenant, owner, leaseId)) return true;
|
String json = redis.opsForValue().get(key(tenant, leaseId));
|
if (json == null) return false;
|
Map<?, ?> state = JsonUtil.getJsonToBean(json, Map.class);
|
UploadEditLease lease = JsonUtil.getJsonToBean(state.get("lease"), UploadEditLease.class);
|
return lease != null && Objects.equals(tenant, lease.getTenantId()) && Objects.equals(owner, lease.getOwnerId())
|
&& Objects.equals(leaseId, lease.getLeaseId());
|
}
|
|
public UploadEditLease find(String tenant, String owner, String leaseId) {
|
UploadEditLease revision = revisionService.find(tenant, owner, leaseId);
|
if (revision != null) return revision;
|
String json = redis.opsForValue().get(key(tenant, leaseId));
|
if (json == null) return null;
|
Map<?, ?> state = JsonUtil.getJsonToBean(json, Map.class);
|
UploadEditLease lease = JsonUtil.getJsonToBean(state.get("lease"), UploadEditLease.class);
|
if (!owner.equals(lease.getOwnerId())) throw new DataException("临时编辑会话不可访问");
|
UploadEditContext context = JsonUtil.getJsonToBean(state.get("context"), UploadEditContext.class);
|
access.authorizeTemporary(context, owner);
|
lease.setAllowDownload(access.allowDownload(context));
|
lease.setQianpiyeAnnotatorEnabled(access.qianpiyeAnnotatorEnabled(context));
|
return lease;
|
}
|
|
/** 清理接口仅撤销本人的临时会话。无 ID 回调不落文件，因此无需删除源文件或历史文件。 */
|
public void cleanup(String leaseId) {
|
UserInfo user = UserProvider.getUser();
|
String tenant = UploadEditDraftService.tenant(user);
|
revisionService.cleanup(tenant, user.getUserId(), leaseId);
|
String key = key(tenant, leaseId);
|
String json = redis.opsForValue().get(key);
|
if (json == null) return;
|
Map<?, ?> state = JsonUtil.getJsonToBean(json, Map.class);
|
UploadEditLease lease = JsonUtil.getJsonToBean(state.get("lease"), UploadEditLease.class);
|
if (!user.getUserId().equals(lease.getOwnerId())) throw new DataException("临时编辑会话不可访问");
|
redis.delete(key);
|
}
|
public boolean saveRevision(UploadEditSaveCommand command) { return revisionService.save(command); }
|
public Map<String, Object> revisionResult(String leaseId) { return revisionService.result(leaseId); }
|
private String key(String tenant, String leaseId) {
|
if (tenant == null || leaseId == null || !leaseId.matches("[a-f0-9]{32}")) throw new DataException("临时编辑标识无效");
|
return "upload-edit:temporary:" + DigestUtil.sha256Hex(tenant) + ":" + leaseId;
|
}
|
}
|
