diff --git a/web-api/ruoyi-admin/src/main/java/com/ruoyi/api/ByteAssetApiController.java b/web-api/ruoyi-admin/src/main/java/com/ruoyi/api/ByteAssetApiController.java new file mode 100644 index 0000000..1940826 --- /dev/null +++ b/web-api/ruoyi-admin/src/main/java/com/ruoyi/api/ByteAssetApiController.java @@ -0,0 +1,101 @@ +package com.ruoyi.api; + +import com.ruoyi.ai.service.IByteAssetService; +import com.ruoyi.common.core.controller.BaseController; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.common.core.request.asset.DeleteAssetRequest; +import com.ruoyi.common.core.request.asset.GetAssetRequest; +import com.ruoyi.common.core.request.asset.ListAssetsRequest; +import com.ruoyi.common.core.request.asset.UpdateAssetRequest; +import com.ruoyi.common.core.response.asset.CreateAssetResponse; +import com.ruoyi.common.core.response.asset.GetAssetResponse; +import com.ruoyi.common.core.response.asset.ListAssetsResponse; +import com.ruoyi.common.core.response.asset.UpdateAssetResponse; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import io.swagger.annotations.ApiParam; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.http.MediaType; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.RequestPart; +import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.multipart.MultipartFile; + +/** + * 火山 - 素材管理（api.docx Assets API）。CreateAsset 先上传存储桶再调三方接口。 + */ +@Slf4j +@RestController +@RequestMapping("/api/byteAsset") +@Api(tags = "火山 - 素材管理") +@RequiredArgsConstructor(onConstructor_ = @Autowired) +public class ByteAssetApiController extends BaseController { + + private final IByteAssetService byteAssetService; + + @PostMapping(value = "/createAsset", consumes = MediaType.MULTIPART_FORM_DATA_VALUE) + @ApiOperation("CreateAsset：先将文件上传至对象存储，再调用 CreateAsset") + public AjaxResult createAsset( + @ApiParam(value = "素材文件", required = true) @RequestPart("file") MultipartFile file, + @ApiParam(value = "所属素材组 Id（GroupId）", required = true) @RequestParam("groupId") String groupId, + @ApiParam(value = "素材类型：Image / Video / Audio", required = true) @RequestParam("assetType") String assetType, + @ApiParam(value = "素材名称，可选") @RequestParam(value = "name", required = false) String name, + @ApiParam(value = "项目名称，可选，默认 default") @RequestParam(value = "projectName", required = false) String projectName) { + try { + return AjaxResult.success(byteAssetService.createAsset(file, groupId, assetType, name, projectName)); + } catch (Exception e) { + log.error("创建素材时发生异常", e); + return AjaxResult.error(e.getMessage()); + } + } + + @PostMapping("/listAssets") + @ApiOperation("ListAssets：查询素材列表") + public AjaxResult listAssets(@RequestBody ListAssetsRequest request) { + try { + return AjaxResult.success(byteAssetService.listAssets(request)); + } catch (Exception e) { + log.error("查询素材列表时发生异常", e); + return AjaxResult.error(e.getMessage()); + } + } + + @PostMapping("/getAsset") + @ApiOperation("GetAsset：查询单个素材") + public AjaxResult getAsset(@RequestBody GetAssetRequest request) { + try { + return AjaxResult.success(byteAssetService.getAsset(request)); + } catch (Exception e) { + log.error("查询素材详情时发生异常", e); + return AjaxResult.error(e.getMessage()); + } + } + + @PostMapping("/updateAsset") + @ApiOperation("UpdateAsset：更新素材（当前仅名称）") + public AjaxResult updateAsset(@RequestBody UpdateAssetRequest request) { + try { + return AjaxResult.success(byteAssetService.updateAsset(request)); + } catch (Exception e) { + log.error("更新素材时发生异常", e); + return AjaxResult.error(e.getMessage()); + } + } + + @PostMapping("/deleteAsset") + @ApiOperation("DeleteAsset：删除素材") + public AjaxResult deleteAsset(@RequestBody DeleteAssetRequest request) { + try { + byteAssetService.deleteAsset(request); + return AjaxResult.success(); + } catch (Exception e) { + log.error("删除素材时发生异常", e); + return AjaxResult.error(e.getMessage()); + } + } +} diff --git a/web-api/ruoyi-admin/src/main/java/com/ruoyi/api/ByteAssetGroupApiController.java b/web-api/ruoyi-admin/src/main/java/com/ruoyi/api/ByteAssetGroupApiController.java new file mode 100644 index 0000000..38bd1a6 --- /dev/null +++ b/web-api/ruoyi-admin/src/main/java/com/ruoyi/api/ByteAssetGroupApiController.java @@ -0,0 +1,79 @@ +package com.ruoyi.api; + +import com.ruoyi.ai.service.IByteAssetGroupService; +import com.ruoyi.common.core.controller.BaseController; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.common.core.request.asset.CreateAssetGroupRequest; +import com.ruoyi.common.core.request.asset.GetAssetGroupRequest; +import com.ruoyi.common.core.request.asset.ListAssetsGroupRequest; +import com.ruoyi.common.core.request.asset.UpdateAssetGroupRequest; +import com.ruoyi.common.core.response.asset.CreateAssetGroupResponse; +import com.ruoyi.common.core.response.asset.GetAssetGroupResponse; +import com.ruoyi.common.core.response.asset.ListAssetsGroupResponse; +import com.ruoyi.common.core.response.asset.UpdateAssetGroupResponse; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + * 火山 - 素材组管理 Controller + */ +@Slf4j +@RestController +@RequestMapping("/api/byteAssetGroup") +@Api(tags = "火山 - 素材组管理") +@RequiredArgsConstructor(onConstructor_ = @Autowired) +public class ByteAssetGroupApiController extends BaseController { + + private final IByteAssetGroupService groupService; + + @PostMapping("/listAssetGroups") + @ApiOperation("ListAssetGroups：查询素材资产组合列表") + public AjaxResult listAssetGroups(@RequestBody ListAssetsGroupRequest request) { + try { + return AjaxResult.success(groupService.listAssetGroups(request)); + } catch (Exception e) { + log.error("查询素材组列表时发生异常", e); + return AjaxResult.error(e.getMessage()); + } + } + + @PostMapping("/createAssetGroup") + @ApiOperation("CreateAssetGroup：创建素材资产组合") + public AjaxResult createAssetGroup(@RequestBody CreateAssetGroupRequest request) { + try { + return AjaxResult.success(groupService.createAssetGroup(request)); + } catch (Exception e) { + log.error("创建素材组时发生异常", e); + return AjaxResult.error(e.getMessage()); + } + } + + @PostMapping("/getAssetGroup") + @ApiOperation("GetAssetGroup：查询单个素材资产组合") + public AjaxResult getAssetGroup(@RequestBody GetAssetGroupRequest request) { + try { + return AjaxResult.success(groupService.getAssetGroup(request)); + } catch (Exception e) { + log.error("查询素材组详情时发生异常", e); + return AjaxResult.error(e.getMessage()); + } + } + + @PostMapping("/updateAssetGroup") + @ApiOperation("UpdateAssetGroup：更新素材资产组合") + public AjaxResult updateAssetGroup(@RequestBody UpdateAssetGroupRequest request) { + try { + return AjaxResult.success(groupService.updateAssetGroup(request)); + } catch (Exception e) { + log.error("更新素材组时发生异常", e); + return AjaxResult.error(e.getMessage()); + } + } +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/CreateAssetGroupRequest.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/CreateAssetGroupRequest.java new file mode 100644 index 0000000..0f1678f --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/CreateAssetGroupRequest.java @@ -0,0 +1,28 @@ +package com.ruoyi.common.core.request.asset; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * CreateAssetGroup — POST /open/CreateAssetGroup（api.docx） + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "创建 Asset Group（素材资产组合）。首次创建需在控制台签署授权函。") +public class CreateAssetGroupRequest { + @ApiModelProperty(value = "Asset Group（素材资产组合）的名称，上限为 64 字符。", required = true) + private String name; + + @ApiModelProperty(value = "Asset Group（素材资产组合）的描述，上限为 300 字符。") + private String description; + + @ApiModelProperty(value = "Asset Group（素材资产组合）的类型。可选值：AIGC：虚拟人像。当前仅支持 AIGC 类型。") + private String groupType; + + @ApiModelProperty(value = "资源所属的项目名称，默认值为 default。若资源不在默认项目中，需填写正确的项目名称。") + private String projectName; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/CreateAssetOpenApiRequest.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/CreateAssetOpenApiRequest.java new file mode 100644 index 0000000..ca6ce4c --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/CreateAssetOpenApiRequest.java @@ -0,0 +1,33 @@ +package com.ruoyi.common.core.request.asset; + +import com.fasterxml.jackson.annotation.JsonProperty; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * CreateAsset — POST /open/CreateAsset 请求体（api.docx）。由服务端在上传存储桶后组装 URL。 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "CreateAsset 第三方接口请求体") +public class CreateAssetOpenApiRequest { + @ApiModelProperty(value = "Asset（素材资产）所属的 Asset Group（素材资产组合）的 Id。", required = true) + private String groupId; + + @JsonProperty("URL") + @ApiModelProperty(value = "传入的 Asset（素材资产）的公共可访问地址。", required = true) + private String url; + + @ApiModelProperty(value = "Asset（素材资产）的名称，上限为 64 个字符。仅用于 ListAssets 模糊搜索，不参与模型推理。") + private String name; + + @ApiModelProperty(value = "Asset（素材资产）的类型。可选值：Image、Video、Audio。", required = true) + private String assetType; + + @ApiModelProperty(value = "资源所属的项目名称，默认 default。需与所属 Asset Group 的 ProjectName 一致。") + private String projectName; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/DeleteAssetRequest.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/DeleteAssetRequest.java new file mode 100644 index 0000000..ba22a0b --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/DeleteAssetRequest.java @@ -0,0 +1,22 @@ +package com.ruoyi.common.core.request.asset; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * DeleteAsset — POST /open/DeleteAsset（api.docx） + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "删除单个 Asset（素材资产）") +public class DeleteAssetRequest { + @ApiModelProperty(value = "需要删除的 Asset（素材资产）的 Id。", required = true) + private String id; + + @ApiModelProperty(value = "需要删除的 Asset（素材资产）所属的项目名称，默认 default。") + private String projectName; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/GetAssetGroupRequest.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/GetAssetGroupRequest.java new file mode 100644 index 0000000..dbf0b36 --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/GetAssetGroupRequest.java @@ -0,0 +1,22 @@ +package com.ruoyi.common.core.request.asset; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * GetAssetGroup — POST /open/GetAssetGroup（api.docx） + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "获取单个 Asset Group（素材资产组合）信息") +public class GetAssetGroupRequest { + @ApiModelProperty(value = "Asset Group（素材资产组合）的 Id。", required = true) + private String id; + + @ApiModelProperty(value = "需要查询的 Asset Group（素材资产组合）所属的项目名称，默认值为 default。若资源不在默认项目中，需填写正确的项目名称。") + private String projectName; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/GetAssetRequest.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/GetAssetRequest.java new file mode 100644 index 0000000..8f3bee7 --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/GetAssetRequest.java @@ -0,0 +1,22 @@ +package com.ruoyi.common.core.request.asset; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * GetAsset — POST /open/GetAsset（api.docx） + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "获取单个 Asset（素材资产）信息") +public class GetAssetRequest { + @ApiModelProperty(value = "Asset（素材资产）的 Id。", required = true) + private String id; + + @ApiModelProperty(value = "需要查询的 Asset 所属的项目名称，默认 default。") + private String projectName; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/ListAssetsGroupRequest.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/ListAssetsGroupRequest.java new file mode 100644 index 0000000..7f50dd2 --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/ListAssetsGroupRequest.java @@ -0,0 +1,35 @@ +package com.ruoyi.common.core.request.asset; + +import com.ruoyi.common.core.request.asset.dto.ListAssetsGroupFilter; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * ListAssetGroups — POST /open/ListAssetGroups（api.docx） + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "查询符合筛选条件的 Asset Groups（素材资产组合）列表") +public class ListAssetsGroupRequest { + @ApiModelProperty(value = "搜索的过滤条件。", required = true) + private ListAssetsGroupFilter filter; + + @ApiModelProperty(value = "搜索页码，可用于列表分页功能，从 1 开始。", required = true) + private int pageNumber; + + @ApiModelProperty(value = "每页搜索结果的数量，上限为 100。", required = true) + private int pageSize; + + @ApiModelProperty(value = "用于排序的字段名称，默认值 createTime。支持：CreateTime（创建时间）、UpdateTime（更新时间）。") + private String sortBy; + + @ApiModelProperty(value = "排序顺序，默认值 Desc。可选值：Desc（降序）、Asc（升序）。") + private String sortOrder; + + @ApiModelProperty(value = "资源所属的项目名称，默认值为 default。若资源不在默认项目中，需填写正确的项目名称。") + private String projectName; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/ListAssetsRequest.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/ListAssetsRequest.java new file mode 100644 index 0000000..dc12a5a --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/ListAssetsRequest.java @@ -0,0 +1,35 @@ +package com.ruoyi.common.core.request.asset; + +import com.ruoyi.common.core.request.asset.dto.ListAssetsFilter; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * ListAssets — POST /open/ListAssets（api.docx） + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "查询符合筛选条件的 Assets（素材资产）列表") +public class ListAssetsRequest { + @ApiModelProperty(value = "搜索的过滤条件。", required = true) + private ListAssetsFilter filter; + + @ApiModelProperty(value = "搜索页码，从 1 开始。", required = true) + private int pageNumber; + + @ApiModelProperty(value = "每页搜索结果的数量，上限为 100。", required = true) + private int pageSize; + + @ApiModelProperty(value = "排序字段，默认 createTime。支持：CreateTime、UpdateTime、GroupId。") + private String sortBy; + + @ApiModelProperty(value = "排序顺序，默认 Desc。可选：Desc、Asc。") + private String sortOrder; + + @ApiModelProperty(value = "资源所属的项目名称，默认 default。") + private String projectName; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/UpdateAssetGroupRequest.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/UpdateAssetGroupRequest.java new file mode 100644 index 0000000..c5c69cc --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/UpdateAssetGroupRequest.java @@ -0,0 +1,28 @@ +package com.ruoyi.common.core.request.asset; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * UpdateAssetGroup — POST /open/UpdateAssetGroup（api.docx） + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "更新单个 Asset Group（素材资产组合）信息。当前仅支持更新 Name 和 Description。") +public class UpdateAssetGroupRequest { + @ApiModelProperty(value = "需要更新的 Asset Group（素材资产组合）的 Id。", required = true) + private String id; + + @ApiModelProperty(value = "需要更新的 Asset Group（素材资产组合）的新名称，上限为 64 个字符。") + private String name; + + @ApiModelProperty(value = "需要更新的 Asset Group（素材资产组合）的新描述，上限为 300 字符。") + private String description; + + @ApiModelProperty(value = "需要更新的 Asset Group（素材资产组合）所属的项目名称，默认值为 default。若资源不在默认项目中，需填写正确的项目名称。") + private String projectName; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/UpdateAssetRequest.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/UpdateAssetRequest.java new file mode 100644 index 0000000..75aad0c --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/UpdateAssetRequest.java @@ -0,0 +1,25 @@ +package com.ruoyi.common.core.request.asset; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * UpdateAsset — POST /open/UpdateAsset（api.docx） + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "更新单个 Asset（素材资产）信息，当前仅支持更新 Name。") +public class UpdateAssetRequest { + @ApiModelProperty(value = "需要更新的 Asset（素材资产）的 Id。", required = true) + private String id; + + @ApiModelProperty(value = "需要更新的 Asset（素材资产）的新名称，上限为 64 个字符。") + private String name; + + @ApiModelProperty(value = "需要更新的 Asset（素材资产）所属的项目名称，默认 default。") + private String projectName; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/dto/ListAssetsFilter.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/dto/ListAssetsFilter.java new file mode 100644 index 0000000..820f223 --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/dto/ListAssetsFilter.java @@ -0,0 +1,30 @@ +package com.ruoyi.common.core.request.asset.dto; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.util.List; + +/** + * ListAssets 请求中的 Filter（api.docx） + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "ListAssets 过滤条件") +public class ListAssetsFilter { + @ApiModelProperty(value = "Asset（素材资产）所属的 Asset Group（素材资产组合）的 Id 列表。") + private List groupIds; + + @ApiModelProperty(value = "Asset Group（素材资产组合）的类型。可选值：AIGC：虚拟人像。", required = true) + private String groupType; + + @ApiModelProperty(value = "任务状态列表：Active（已处理完毕）、Processing（预处理中）、Failed（处理失败）。") + private List statuses; + + @ApiModelProperty(value = "Asset（素材资产）的名称，上限为 64 个字符（模糊搜索）。") + private String name; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/dto/ListAssetsGroupFilter.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/dto/ListAssetsGroupFilter.java new file mode 100644 index 0000000..66368bd --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/dto/ListAssetsGroupFilter.java @@ -0,0 +1,27 @@ +package com.ruoyi.common.core.request.asset.dto; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.util.List; + +/** + * ListAssetGroups 请求中的 Filter 对象（api.docx） + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "ListAssetGroups 过滤条件") +public class ListAssetsGroupFilter { + @ApiModelProperty(value = "Asset Group（素材资产组合）的名称，上限为 64 个字符（模糊搜索）。") + private String name; + + @ApiModelProperty(value = "Asset（素材资产）所属的 Asset Group（素材资产组合）的 Id 列表。") + private List groupIds; + + @ApiModelProperty(value = "Asset Group（素材资产组合）的类型。可选值：AIGC：虚拟人像。", required = true) + private String groupType; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/CreateAssetGroupResponse.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/CreateAssetGroupResponse.java new file mode 100644 index 0000000..11a939d --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/CreateAssetGroupResponse.java @@ -0,0 +1,16 @@ +package com.ruoyi.common.core.response.asset; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "CreateAssetGroup 返回参数") +public class CreateAssetGroupResponse { + @ApiModelProperty(value = "Asset Group（素材资产组合）的 Id。") + private String id; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/CreateAssetResponse.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/CreateAssetResponse.java new file mode 100644 index 0000000..134bdcd --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/CreateAssetResponse.java @@ -0,0 +1,16 @@ +package com.ruoyi.common.core.response.asset; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "CreateAsset 返回参数") +public class CreateAssetResponse { + @ApiModelProperty(value = "Asset（素材资产）的 Id。") + private String id; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/GetAssetGroupResponse.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/GetAssetGroupResponse.java new file mode 100644 index 0000000..5cb176a --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/GetAssetGroupResponse.java @@ -0,0 +1,37 @@ +package com.ruoyi.common.core.response.asset; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "GetAssetGroup 返回参数") +public class GetAssetGroupResponse { + @ApiModelProperty(value = "Asset Group（素材资产组合）的 Id。") + private String id; + + @ApiModelProperty(value = "Asset Group（素材资产组合）的名称，上限为 64 个字符。") + private String name; + + @ApiModelProperty(value = "Asset Group（素材资产组合）的标题。已废弃，请直接使用参数 Name。") + private String title; + + @ApiModelProperty(value = "Asset Group（素材资产组合）的描述，上限为 300 字符。") + private String description; + + @ApiModelProperty(value = "Asset Group（素材资产组合）的类型。AIGC：虚拟人像。") + private String groupType; + + @ApiModelProperty(value = "资源所属的项目名称。") + private String projectName; + + @ApiModelProperty(value = "创建时间。") + private String createTime; + + @ApiModelProperty(value = "更新时间。") + private String updateTime; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/GetAssetResponse.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/GetAssetResponse.java new file mode 100644 index 0000000..5483902 --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/GetAssetResponse.java @@ -0,0 +1,46 @@ +package com.ruoyi.common.core.response.asset; + +import com.fasterxml.jackson.annotation.JsonProperty; +import com.ruoyi.common.core.response.asset.dto.AssetError; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "GetAsset 返回参数") +public class GetAssetResponse { + @ApiModelProperty(value = "Asset（素材资产）的 Id。") + private String id; + + @ApiModelProperty(value = "Asset（素材资产）的名称，上限为 64 个字符。") + private String name; + + @JsonProperty("URL") + @ApiModelProperty(value = "Asset（素材资产）的访问地址。有效期为 12 小时，请及时保存。") + private String url; + + @ApiModelProperty(value = "Asset（素材资产）的类型：Image、Video、Audio。") + private String assetType; + + @ApiModelProperty(value = "Asset（素材资产）所属的 Asset Group（素材资产组合）的 Id。") + private String groupId; + + @ApiModelProperty(value = "任务状态：Active、Processing、Failed。") + private String status; + + @ApiModelProperty(value = "错误信息。") + private AssetError error; + + @ApiModelProperty(value = "创建时间。") + private String createTime; + + @ApiModelProperty(value = "更新时间。") + private String updateTime; + + @ApiModelProperty(value = "资源所属的项目名称。") + private String projectName; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/ListAssetsGroupResponse.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/ListAssetsGroupResponse.java new file mode 100644 index 0000000..3a9da4c --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/ListAssetsGroupResponse.java @@ -0,0 +1,28 @@ +package com.ruoyi.common.core.response.asset; + +import com.ruoyi.common.core.response.asset.dto.ListAssetsGroup; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.util.List; + +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "ListAssetGroups 返回参数") +public class ListAssetsGroupResponse { + @ApiModelProperty(value = "返回的 Asset Group（素材资产组合）的总数。") + private int totalCount; + + @ApiModelProperty(value = "返回的页数。") + private int pageNumber; + + @ApiModelProperty(value = "每页搜索结果的数量，上限为 100。") + private int pageSize; + + @ApiModelProperty(value = "符合筛选条件的 Asset Group（素材资产组合）数组。") + private List items; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/ListAssetsResponse.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/ListAssetsResponse.java new file mode 100644 index 0000000..a2c3b0f --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/ListAssetsResponse.java @@ -0,0 +1,28 @@ +package com.ruoyi.common.core.response.asset; + +import com.ruoyi.common.core.response.asset.dto.ListAssetItem; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.util.List; + +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "ListAssets 返回参数") +public class ListAssetsResponse { + @ApiModelProperty(value = "符合筛选条件的 Asset 数组。") + private List items; + + @ApiModelProperty(value = "返回总数。") + private int totalCount; + + @ApiModelProperty(value = "返回的页数。") + private int pageNumber; + + @ApiModelProperty(value = "每页搜索结果的数量，上限为 100。") + private int pageSize; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/UpdateAssetGroupResponse.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/UpdateAssetGroupResponse.java new file mode 100644 index 0000000..99f90a2 --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/UpdateAssetGroupResponse.java @@ -0,0 +1,16 @@ +package com.ruoyi.common.core.response.asset; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "UpdateAssetGroup 返回参数") +public class UpdateAssetGroupResponse { + @ApiModelProperty(value = "Asset Group（素材资产组合）的 Id。") + private String id; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/UpdateAssetResponse.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/UpdateAssetResponse.java new file mode 100644 index 0000000..85dbe87 --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/UpdateAssetResponse.java @@ -0,0 +1,16 @@ +package com.ruoyi.common.core.response.asset; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "UpdateAsset 返回参数") +public class UpdateAssetResponse { + @ApiModelProperty(value = "Asset（素材资产）的 Id。") + private String id; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/dto/AssetError.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/dto/AssetError.java new file mode 100644 index 0000000..2e14bba --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/dto/AssetError.java @@ -0,0 +1,19 @@ +package com.ruoyi.common.core.response.asset.dto; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "素材处理错误信息") +public class AssetError { + @ApiModelProperty(value = "错误码。") + private String code; + + @ApiModelProperty(value = "错误信息。") + private String message; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/dto/ListAssetItem.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/dto/ListAssetItem.java new file mode 100644 index 0000000..27c8bdd --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/dto/ListAssetItem.java @@ -0,0 +1,47 @@ +package com.ruoyi.common.core.response.asset.dto; + +import com.fasterxml.jackson.annotation.JsonProperty; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * ListAssets 返回 Items 元素（api.docx） + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "素材资产（列表项）") +public class ListAssetItem { + @ApiModelProperty(value = "Asset（素材资产）的 Id。") + private String id; + + @ApiModelProperty(value = "Asset（素材资产）的名称，上限为 64 个字符。") + private String name; + + @ApiModelProperty(value = "Asset（素材资产）的公共可访问地址。有效期为 12 小时，请及时保存。") + private String url; + + @ApiModelProperty(value = "Asset（素材资产）所属的 Asset Group（素材资产组合）的 Id。") + private String groupId; + + @ApiModelProperty(value = "Asset（素材资产）的类型：Image、Video、Audio。") + private String assetType; + + @ApiModelProperty(value = "任务状态：Active、Processing、Failed。") + private String status; + + @ApiModelProperty(value = "错误信息（处理失败时）。") + private AssetError error; + + @ApiModelProperty(value = "资源所属的项目名称。") + private String projectName; + + @ApiModelProperty(value = "创建时间。") + private String createTime; + + @ApiModelProperty(value = "更新时间。") + private String updateTime; +} diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/dto/ListAssetsGroup.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/dto/ListAssetsGroup.java new file mode 100644 index 0000000..a4e94eb --- /dev/null +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/dto/ListAssetsGroup.java @@ -0,0 +1,40 @@ +package com.ruoyi.common.core.response.asset.dto; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * ListAssetGroups 返回 Items 元素（api.docx） + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@ApiModel(description = "素材资产组合（列表项）") +public class ListAssetsGroup { + @ApiModelProperty(value = "Asset Group（素材资产组合）的 Id。") + private String id; + + @ApiModelProperty(value = "Asset Group（素材资产组合）的名称，上限为 64 个字符。") + private String name; + + @ApiModelProperty(value = "Asset Group（素材资产组合）的标题。已废弃，请直接使用参数 Name。") + private String title; + + @ApiModelProperty(value = "Asset Group（素材资产组合）的描述，上限为 300 字符。") + private String description; + + @ApiModelProperty(value = "Asset Group（素材资产组合）的类型。AIGC：虚拟人像。") + private String groupType; + + @ApiModelProperty(value = "资源所属的项目名称。") + private String projectName; + + @ApiModelProperty(value = "创建时间。") + private String createTime; + + @ApiModelProperty(value = "更新时间。") + private String updateTime; +} diff --git a/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/IByteAssetGroupService.java b/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/IByteAssetGroupService.java new file mode 100644 index 0000000..3090fdc --- /dev/null +++ b/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/IByteAssetGroupService.java @@ -0,0 +1,23 @@ +package com.ruoyi.ai.service; + +import com.ruoyi.common.core.request.asset.CreateAssetGroupRequest; +import com.ruoyi.common.core.request.asset.GetAssetGroupRequest; +import com.ruoyi.common.core.request.asset.ListAssetsGroupRequest; +import com.ruoyi.common.core.request.asset.UpdateAssetGroupRequest; +import com.ruoyi.common.core.response.asset.CreateAssetGroupResponse; +import com.ruoyi.common.core.response.asset.GetAssetGroupResponse; +import com.ruoyi.common.core.response.asset.ListAssetsGroupResponse; +import com.ruoyi.common.core.response.asset.UpdateAssetGroupResponse; + +import java.io.IOException; + +public interface IByteAssetGroupService { + + ListAssetsGroupResponse listAssetGroups(ListAssetsGroupRequest request) throws IOException; + + CreateAssetGroupResponse createAssetGroup(CreateAssetGroupRequest request) throws IOException; + + GetAssetGroupResponse getAssetGroup(GetAssetGroupRequest request) throws IOException; + + UpdateAssetGroupResponse updateAssetGroup(UpdateAssetGroupRequest request) throws IOException; +} diff --git a/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/IByteAssetService.java b/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/IByteAssetService.java new file mode 100644 index 0000000..349b81c --- /dev/null +++ b/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/IByteAssetService.java @@ -0,0 +1,29 @@ +package com.ruoyi.ai.service; + +import com.ruoyi.common.core.request.asset.DeleteAssetRequest; +import com.ruoyi.common.core.request.asset.GetAssetRequest; +import com.ruoyi.common.core.request.asset.ListAssetsRequest; +import com.ruoyi.common.core.request.asset.UpdateAssetRequest; +import com.ruoyi.common.core.response.asset.CreateAssetResponse; +import com.ruoyi.common.core.response.asset.GetAssetResponse; +import com.ruoyi.common.core.response.asset.ListAssetsResponse; +import com.ruoyi.common.core.response.asset.UpdateAssetResponse; +import org.springframework.web.multipart.MultipartFile; + +import java.io.IOException; + +public interface IByteAssetService { + + /** + * 先将文件上传至对象存储得到公网 URL，再调用 CreateAsset。 + */ + CreateAssetResponse createAsset(MultipartFile file, String groupId, String assetType, String name, String projectName) throws Exception; + + ListAssetsResponse listAssets(ListAssetsRequest request) throws IOException; + + GetAssetResponse getAsset(GetAssetRequest request) throws IOException; + + UpdateAssetResponse updateAsset(UpdateAssetRequest request) throws IOException; + + void deleteAsset(DeleteAssetRequest request) throws IOException; +} diff --git a/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/BaseByteApiService.java b/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/BaseByteApiService.java new file mode 100644 index 0000000..e005ec1 --- /dev/null +++ b/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/BaseByteApiService.java @@ -0,0 +1,88 @@ +package com.ruoyi.ai.service.impl; + +import com.fasterxml.jackson.annotation.JsonInclude; +import com.fasterxml.jackson.databind.DeserializationFeature; +import com.fasterxml.jackson.databind.JsonNode; +import com.fasterxml.jackson.databind.MapperFeature; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.fasterxml.jackson.databind.PropertyNamingStrategies; +import com.ruoyi.common.utils.http.OkHttpUtils; +import okhttp3.MediaType; +import okhttp3.Request; +import okhttp3.RequestBody; +import okhttp3.Response; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.stereotype.Service; + +import java.io.IOException; + +@Service +public class BaseByteApiService { + protected final ObjectMapper objectMapper = new ObjectMapper() + .setSerializationInclusion(JsonInclude.Include.NON_NULL) + .setPropertyNamingStrategy(PropertyNamingStrategies.UPPER_CAMEL_CASE) + .configure(MapperFeature.ACCEPT_CASE_INSENSITIVE_PROPERTIES, true) + .configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false) + .configure(DeserializationFeature.ACCEPT_EMPTY_STRING_AS_NULL_OBJECT, true); + + // API地址（可配置在配置文件中） + @Value("${byteapi.url}") + protected String API_URL; + + @Value("${byteapi.apiKey}") + protected String apiKey; + + /** + * POST JSON 调用方舟 OpenAPI；若响应含 {@code Result} 节点则解析为业务对象（与 api.docx 返回示例一致）。 + */ + protected T httpExecute(String path, Object request, Class clz) throws IOException { + String jsonBody = objectMapper.writeValueAsString(request); + RequestBody body = RequestBody.create( + MediaType.parse("application/json; charset=utf-8"), + jsonBody); + Request httpRequest = new Request.Builder() + .url(API_URL + path) + .header("Content-Type", "application/json") + .header("Authorization", "Bearer " + apiKey) + .post(body) + .build(); + try (Response response = OkHttpUtils.newCall(httpRequest).execute()) { + if (!response.isSuccessful()) { + String errorMsg = response.body() != null ? response.body().string() : "execute error"; + throw new RuntimeException("execute error：" + errorMsg); + } + if (response.body() == null) { + throw new RuntimeException("response body null"); + } + String responseBody = response.body().string(); + JsonNode root = objectMapper.readTree(responseBody); + JsonNode result = root.get("Result"); + if (result != null && !result.isNull()) { + return objectMapper.treeToValue(result, clz); + } + return objectMapper.readValue(responseBody, clz); + } + } + + /** + * 无业务体返回的 OpenAPI 调用（如 DeleteAsset）。 + */ + protected void httpExecuteNoContent(String path, Object request) throws IOException { + String jsonBody = objectMapper.writeValueAsString(request); + RequestBody body = RequestBody.create( + MediaType.parse("application/json; charset=utf-8"), + jsonBody); + Request httpRequest = new Request.Builder() + .url(API_URL + path) + .header("Content-Type", "application/json") + .header("Authorization", "Bearer " + apiKey) + .post(body) + .build(); + try (Response response = OkHttpUtils.newCall(httpRequest).execute()) { + if (!response.isSuccessful()) { + String errorMsg = response.body() != null ? response.body().string() : "execute error"; + throw new RuntimeException("execute error：" + errorMsg); + } + } + } +} \ No newline at end of file diff --git a/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/ByteAssetGroupService.java b/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/ByteAssetGroupService.java new file mode 100644 index 0000000..48178e5 --- /dev/null +++ b/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/ByteAssetGroupService.java @@ -0,0 +1,43 @@ +package com.ruoyi.ai.service.impl; + +import com.ruoyi.ai.service.IByteAssetGroupService; +import com.ruoyi.common.core.request.asset.CreateAssetGroupRequest; +import com.ruoyi.common.core.request.asset.GetAssetGroupRequest; +import com.ruoyi.common.core.request.asset.ListAssetsGroupRequest; +import com.ruoyi.common.core.request.asset.UpdateAssetGroupRequest; +import com.ruoyi.common.core.response.asset.CreateAssetGroupResponse; +import com.ruoyi.common.core.response.asset.GetAssetGroupResponse; +import com.ruoyi.common.core.response.asset.ListAssetsGroupResponse; +import com.ruoyi.common.core.response.asset.UpdateAssetGroupResponse; +import org.springframework.stereotype.Service; + +import java.io.IOException; + +@Service +public class ByteAssetGroupService extends BaseByteApiService implements IByteAssetGroupService { + + private static final String LIST_ASSET_GROUPS_URL = "/open/ListAssetGroups"; + private static final String CREATE_ASSET_GROUP_URL = "/open/CreateAssetGroup"; + private static final String GET_ASSET_GROUP_URL = "/open/GetAssetGroup"; + private static final String UPDATE_ASSET_GROUP_URL = "/open/UpdateAssetGroup"; + + @Override + public ListAssetsGroupResponse listAssetGroups(ListAssetsGroupRequest request) throws IOException { + return httpExecute(LIST_ASSET_GROUPS_URL, request, ListAssetsGroupResponse.class); + } + + @Override + public CreateAssetGroupResponse createAssetGroup(CreateAssetGroupRequest request) throws IOException { + return httpExecute(CREATE_ASSET_GROUP_URL, request, CreateAssetGroupResponse.class); + } + + @Override + public GetAssetGroupResponse getAssetGroup(GetAssetGroupRequest request) throws IOException { + return httpExecute(GET_ASSET_GROUP_URL, request, GetAssetGroupResponse.class); + } + + @Override + public UpdateAssetGroupResponse updateAssetGroup(UpdateAssetGroupRequest request) throws IOException { + return httpExecute(UPDATE_ASSET_GROUP_URL, request, UpdateAssetGroupResponse.class); + } +} diff --git a/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/ByteAssetService.java b/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/ByteAssetService.java new file mode 100644 index 0000000..0f088eb --- /dev/null +++ b/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/ByteAssetService.java @@ -0,0 +1,70 @@ +package com.ruoyi.ai.service.impl; + +import com.ruoyi.ai.service.IByteAssetService; +import com.ruoyi.common.core.request.asset.CreateAssetOpenApiRequest; +import com.ruoyi.common.core.request.asset.DeleteAssetRequest; +import com.ruoyi.common.core.request.asset.GetAssetRequest; +import com.ruoyi.common.core.request.asset.ListAssetsRequest; +import com.ruoyi.common.core.request.asset.UpdateAssetRequest; +import com.ruoyi.common.core.response.asset.CreateAssetResponse; +import com.ruoyi.common.core.response.asset.GetAssetResponse; +import com.ruoyi.common.core.response.asset.ListAssetsResponse; +import com.ruoyi.common.core.response.asset.UpdateAssetResponse; +import com.ruoyi.common.utils.AwsS3Util; +import com.ruoyi.common.utils.StringUtils; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; +import org.springframework.web.multipart.MultipartFile; + +import java.io.IOException; + +@Service +@RequiredArgsConstructor +public class ByteAssetService extends BaseByteApiService implements IByteAssetService { + + private final AwsS3Util awsS3Util; + + private static final String CREATE_ASSET_URL = "/open/CreateAsset"; + private static final String LIST_ASSETS_URL = "/open/ListAssets"; + private static final String GET_ASSET_URL = "/open/GetAsset"; + private static final String UPDATE_ASSET_URL = "/open/UpdateAsset"; + private static final String DELETE_ASSET_URL = "/open/DeleteAsset"; + + @Override + public CreateAssetResponse createAsset(MultipartFile file, String groupId, String assetType, String name, String projectName) throws Exception { + if (file == null || file.isEmpty()) { + throw new IllegalArgumentException("上传文件不能为空"); + } + if (StringUtils.isBlank(groupId) || StringUtils.isBlank(assetType)) { + throw new IllegalArgumentException("groupId、assetType 不能为空"); + } + String publicUrl = awsS3Util.uploadMultipartFile(file, true); + CreateAssetOpenApiRequest body = new CreateAssetOpenApiRequest(); + body.setGroupId(groupId); + body.setUrl(publicUrl); + body.setName(name); + body.setAssetType(assetType); + body.setProjectName(projectName); + return httpExecute(CREATE_ASSET_URL, body, CreateAssetResponse.class); + } + + @Override + public ListAssetsResponse listAssets(ListAssetsRequest request) throws IOException { + return httpExecute(LIST_ASSETS_URL, request, ListAssetsResponse.class); + } + + @Override + public GetAssetResponse getAsset(GetAssetRequest request) throws IOException { + return httpExecute(GET_ASSET_URL, request, GetAssetResponse.class); + } + + @Override + public UpdateAssetResponse updateAsset(UpdateAssetRequest request) throws IOException { + return httpExecute(UPDATE_ASSET_URL, request, UpdateAssetResponse.class); + } + + @Override + public void deleteAsset(DeleteAssetRequest request) throws IOException { + httpExecuteNoContent(DELETE_ASSET_URL, request); + } +}