best_yunwei
/
ai_images
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat： 火山素材组、素材管理

This commit is contained in:
yys 2026-03-31 18:32:10 +08:00
parent a04bd71afc
commit f9c12bb1e0
29 changed files with 1049 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

101
web-api/ruoyi-admin/src/main/java/com/ruoyi/api/ByteAssetApiController.java Normal file
View File

@ -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<CreateAssetResponse> 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<ListAssetsResponse> 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<GetAssetResponse> 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<UpdateAssetResponse> 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<Void> deleteAsset(@RequestBody DeleteAssetRequest request) {
try {
byteAssetService.deleteAsset(request);
return AjaxResult.success();
} catch (Exception e) {
log.error("删除素材时发生异常", e);
return AjaxResult.error(e.getMessage());
}
}
}

79
web-api/ruoyi-admin/src/main/java/com/ruoyi/api/ByteAssetGroupApiController.java Normal file
View File

@ -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<ListAssetsGroupResponse> 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<CreateAssetGroupResponse> 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<GetAssetGroupResponse> 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<UpdateAssetGroupResponse> updateAssetGroup(@RequestBody UpdateAssetGroupRequest request) {
try {
return AjaxResult.success(groupService.updateAssetGroup(request));
} catch (Exception e) {
log.error("更新素材组时发生异常", e);
return AjaxResult.error(e.getMessage());
}
}
}

28
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/CreateAssetGroupRequest.java Normal file
View File

@ -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;
}

33
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/CreateAssetOpenApiRequest.java Normal file
View File

@ -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;
}

22
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/DeleteAssetRequest.java Normal file
View File

@ -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;
}

22
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/GetAssetGroupRequest.java Normal file
View File

@ -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;
}

22
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/GetAssetRequest.java Normal file
View File

@ -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;
}

35
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/ListAssetsGroupRequest.java Normal file
View File

@ -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;
}

35
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/ListAssetsRequest.java Normal file
View File

@ -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;
}

28
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/UpdateAssetGroupRequest.java Normal file
View File

@ -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;
}

25
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/UpdateAssetRequest.java Normal file
View File

@ -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;
}

30
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/dto/ListAssetsFilter.java Normal file
View File

@ -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<String> groupIds;
@ApiModelProperty(value = "Asset Group（素材资产组合）的类型。可选值：AIGC：虚拟人像。", required = true)
private String groupType;
@ApiModelProperty(value = "任务状态列表：Active（已处理完毕）、Processing（预处理中）、Failed（处理失败）。")
private List<String> statuses;
@ApiModelProperty(value = "Asset（素材资产）的名称，上限为 64 个字符（模糊搜索）。")
private String name;
}

27
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/request/asset/dto/ListAssetsGroupFilter.java Normal file
View File

@ -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<String> groupIds;
@ApiModelProperty(value = "Asset Group（素材资产组合）的类型。可选值：AIGC：虚拟人像。", required = true)
private String groupType;
}

16
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/CreateAssetGroupResponse.java Normal file
View File

@ -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;
}

16
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/CreateAssetResponse.java Normal file
View File

@ -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;
}

37
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/GetAssetGroupResponse.java Normal file
View File

@ -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;
}

46
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/GetAssetResponse.java Normal file
View File

@ -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;
}

28
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/ListAssetsGroupResponse.java Normal file
View File

@ -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<ListAssetsGroup> items;
}

28
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/ListAssetsResponse.java Normal file
View File

@ -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<ListAssetItem> items;
@ApiModelProperty(value = "返回总数。")
private int totalCount;
@ApiModelProperty(value = "返回的页数。")
private int pageNumber;
@ApiModelProperty(value = "每页搜索结果的数量，上限为 100。")
private int pageSize;
}

16
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/UpdateAssetGroupResponse.java Normal file
View File

@ -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;
}

16
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/UpdateAssetResponse.java Normal file
View File

@ -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;
}

19
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/dto/AssetError.java Normal file
View File

@ -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;
}

47
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/dto/ListAssetItem.java Normal file
View File

@ -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;
}

40
web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/response/asset/dto/ListAssetsGroup.java Normal file
View File

@ -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;
}

23
web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/IByteAssetGroupService.java Normal file
View File

@ -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;
}

29
web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/IByteAssetService.java Normal file
View File

@ -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;
}

88
web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/BaseByteApiService.java Normal file
View File

@ -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> T httpExecute(String path, Object request, Class<T> 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);
}
}
}
}

43
web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/ByteAssetGroupService.java Normal file
View File

@ -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);
}
}

70
web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/ByteAssetService.java Normal file
View File

@ -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);
}
}