package jnpf.onlinedev.service;
|
|
import cn.dev33.satoken.stp.StpUtil;
|
import jnpf.base.UserInfo;
|
import jnpf.base.entity.VisualdevEntity;
|
import jnpf.base.entity.VisualdevReleaseEntity;
|
import jnpf.base.service.UploadEditAccess;
|
import jnpf.base.service.VisualdevReleaseService;
|
import jnpf.base.service.VisualdevService;
|
import jnpf.base.util.FlowFormDataUtil;
|
import jnpf.base.util.UploadEditStateMachine;
|
import jnpf.exception.DataException;
|
import jnpf.exception.WorkFlowException;
|
import jnpf.onlinedev.model.OnlineInfoModel;
|
import jnpf.onlinedev.model.PaginationModel;
|
import jnpf.onlinedev.model.UploadTemplateQuery;
|
import jnpf.onlinedev.util.OnlinePublicUtils;
|
import jnpf.util.JsonUtil;
|
import jnpf.util.TicketUtil;
|
import jnpf.util.UserProvider;
|
import jnpf.util.context.RequestContext;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
|
import java.util.*;
|
|
/** 上传模板入口：复用原生查询与权限，只授权文件引用，不复制文件或保存业务单据。 */
|
@Service
|
@RequiredArgsConstructor
|
public class UploadTemplateService {
|
static final String MODEL_ID = "859351030394158725";
|
static final String MENU_ID = "859363791895428741";
|
private final VisualdevReleaseService releases;
|
private final VisualdevService models;
|
private final VisualDevListService lists;
|
private final FlowFormDataUtil formData;
|
private final UploadEditAccess access;
|
|
public Map<String, Object> list(UploadTemplateQuery query) throws WorkFlowException {
|
access.authorizeTemporary(query.getContext(), UserProvider.getLoginUserId());
|
StpUtil.checkPermission(MODEL_ID);
|
if (query.getCurrentPage() < 1 || query.getCurrentPage() > 100000
|
|| query.getKeyword() != null && query.getKeyword().length() > 200) {
|
throw new DataException("模板查询参数无效");
|
}
|
VisualdevReleaseEntity release = releases.getById(MODEL_ID);
|
VisualdevEntity model = models.getReleaseInfo(MODEL_ID);
|
if (release == null || model == null) throw new DataException("文件/记录模板管理尚未发布");
|
PaginationModel page = new PaginationModel();
|
page.setCurrentPage(query.getCurrentPage());
|
page.setPageSize(20);
|
page.setMenuId(MENU_ID);
|
page.setSystemCode(RequestContext.getAppCode());
|
page.setQueryJson(JsonUtil.getObjectToString(Collections.singletonMap("wenben_mingcheng",
|
Objects.toString(query.getKeyword(), "").trim())));
|
List<Map<String, Object>> rows = lists.getDataList(OnlinePublicUtils.getVisualJsonModel(release), page);
|
List<Map<String, Object>> result = new ArrayList<>();
|
for (Map<String, Object> row : rows) {
|
String id = UploadEditAccess.rowId(row);
|
if (id.isBlank()) continue;
|
// 仅对原生权限查询可见的记录读取详情；详情继续执行源表单字段权限。
|
Map<String, Object> detail = formData.getFilePermissionDataInfo(model, id,
|
OnlineInfoModel.builder().menuId(MENU_ID).build());
|
if (detail == null || detail.isEmpty()) continue;
|
List<Map<String, Object>> files = UploadEditStateMachine.files(detail.get("biz_files")).stream()
|
.filter(UploadTemplateService::isDocx).map(UploadTemplateService::canonical).toList();
|
result.add(Map.of("id", id, "name", Objects.toString(detail.get("wenben_mingcheng"), ""), "files", files));
|
}
|
return Map.of("list", result, "total", page.getTotal(), "currentPage", page.getCurrentPage(), "pageSize", 20);
|
}
|
|
@SuppressWarnings("unchecked")
|
public Map<String, Object> select(UploadTemplateQuery query) throws WorkFlowException {
|
// 重新校验当前页、数据权限及文件成员关系；不接受列表展示时的过期授权。
|
Map<String, Object> page = list(query);
|
List<Map<String, Object>> rows = (List<Map<String, Object>>) page.get("list");
|
Map<String, Object> row = rows.stream().filter(r -> Objects.equals(r.get("id"), query.getTemplateId()))
|
.findFirst().orElseThrow(() -> new DataException("模板已变化或无权使用，请刷新模板列表"));
|
List<Map<String, Object>> files = (List<Map<String, Object>>) row.get("files");
|
Map<String, Object> file = files.stream().filter(f -> Objects.equals(f.get("fileId"), query.getFileId()))
|
.findFirst().orElseThrow(() -> new DataException("模板文件已变化，请重新选择"));
|
UserInfo user = UserProvider.getUser();
|
Map<String, Object> selected = new LinkedHashMap<>(file);
|
jnpf.base.model.uploadedit.UploadEditContext target = new jnpf.base.model.uploadedit.UploadEditContext();
|
target.setModelId(query.getContext().getModelId()); target.setField(query.getContext().getField());
|
target.setParentField(query.getContext().getParentField());
|
if (access.isDmsAuditTemporary(target) && "wenjian".equals(query.getContext().getField())
|
&& (query.getContext().getParentField() == null || query.getContext().getParentField().isBlank()))
|
selected.put(jnpf.base.util.UploadTemplateSource.FIELD, query.getTemplateId());
|
Map<String, Object> proof = new LinkedHashMap<>(selected);
|
proof.put("purpose", "upload-edit-source");
|
proof.put("tenantId", user.getTenantId() == null || user.getTenantId().isEmpty() ? "0" : user.getTenantId());
|
proof.put("ownerId", user.getUserId());
|
Map<String, Object> result = new LinkedHashMap<>(selected);
|
result.put("uploadReceipt", TicketUtil.createTicket(JsonUtil.getObjectToString(proof), 86400L));
|
return result;
|
}
|
|
static boolean isDocx(Map<String, Object> file) {
|
return !Objects.toString(file.get("fileId"), "").isBlank()
|
&& Objects.toString(file.get("name"), "").toLowerCase(Locale.ROOT).endsWith(".docx");
|
}
|
static Map<String, Object> canonical(Map<String, Object> file) {
|
Map<String, Object> result = new LinkedHashMap<>();
|
for (String key : List.of("fileId", "name", "fileSize", "fileExtension", "url", "contentSavedAt")) result.put(key, file.get(key));
|
result.put("fileExtension", "docx");
|
return result;
|
}
|
}
|
