feat:任务执行创建算例

This commit is contained in:
2025-11-17 15:12:25 +08:00
parent 8aebe5d8ca
commit 58846b34cb
18 changed files with 303 additions and 15 deletions

View File

@@ -1,5 +1,6 @@
package com.sdm.common.entity.pojo;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.sdm.common.entity.bo.BaseBean;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
@@ -12,21 +13,24 @@ public class BaseEntity extends BaseBean {
public String company;
@Schema(description = "更新者ID")
@JsonFormat(shape = JsonFormat.Shape.STRING)
public long updater;
@Schema(description = "更新者名称")
public long updateName;
public String updateName;
@Schema(description = "更新时间")
public String updateTime;
@Schema(description = "租户ID")
@JsonFormat(shape = JsonFormat.Shape.STRING)
public Long tenantId;
@Schema(description = "模版创建者名称")
public String createName;
@Schema(description = "创建者ID")
@JsonFormat(shape = JsonFormat.Shape.STRING)
public long creator;
@Schema(description = "创建时间")

View File

@@ -98,4 +98,17 @@ public class DataClientFeignClientImpl implements IDataFeignClient {
}
}
@Override
public SdmResponse<FileMetadataInfoResp> queryFileMetadataInfo(String uuid, String uuidOwnType) {
SdmResponse<FileMetadataInfoResp> response;
try {
response = dataClient.queryFileMetadataInfo(uuid, uuidOwnType);
log.info("查询文件夹响应:"+ response);
return response;
} catch (Exception e) {
log.error("查询文件夹响应", e);
return SdmResponse.failed("查询文件夹响应");
}
}
}

View File

@@ -37,7 +37,11 @@ public interface IDataFeignClient {
@PostMapping("/data/approveDataFile")
SdmResponse approveDataFile(@RequestBody LaunchApproveReq req);
@PostMapping(value = "/uploadSimulationNodeFiles",consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
@PostMapping(value = "/data/uploadFiles",consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
SdmResponse uploadFiles(UploadFilesReq req);
@GetMapping("/data/queryFileMetadataInfo")
SdmResponse<FileMetadataInfoResp> queryFileMetadataInfo(@RequestParam(value = "uuid") String uuid, @RequestParam(value = "uuidOwnType") String uuidOwnType);
}

View File

@@ -22,5 +22,11 @@ public class FeignMdcRequestInterceptor implements RequestInterceptor {
if (tenantId != null) {
template.header("tenantid", String.valueOf(tenantId));
}
// 传递userId
Long userId = ThreadLocalContext.getUserId();
if (userId != null) {
template.header("userid", String.valueOf(userId));
}
}
}