master
RuiSong_WangYi@163.com 2025-02-24 11:31:07 +08:00
parent c2f011a63b
commit 5170ba3378
4 changed files with 81 additions and 32 deletions

View File

@ -1,38 +1,44 @@
package com.muyu.aliyun.bailian; package com.muyu.aliyun.bailian;
import com.aliyun.bailian20231229.Client;
import com.aliyun.bailian20231229.models.AddFileRequest; import com.aliyun.sdk.service.bailian20231229.AsyncClient;
import com.aliyun.bailian20231229.models.AddFileResponse; import com.aliyun.sdk.service.bailian20231229.models.AddFileRequest;
import com.aliyun.bailian20231229.models.AddFileResponseBody; import com.aliyun.sdk.service.bailian20231229.models.AddFileResponse;
import com.aliyun.tea.TeaException;
import com.aliyun.teautil.models.RuntimeOptions;
import com.muyu.aliyun.bailian.data.UploadDataManagementMode; import com.muyu.aliyun.bailian.data.UploadDataManagementMode;
import com.muyu.aliyun.bailian.data.fixed.AddFileResponseBodyDataMode; import com.muyu.aliyun.bailian.data.fixed.AddFileResponseBodyDataMode;
import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.util.concurrent.CompletableFuture;
import com.aliyun.sdk.service.bailian20231229.models.AddFileResponseBody;
import java.util.HashMap;
import java.util.Map;
@Component @Component
@Log4j2 @Log4j2
public class AddDataManagement { public class AddDataManagement {
// @Autowired @Autowired
private Client client; private AsyncClient client;
public AddFileResponseBodyDataMode addFile(UploadDataManagementMode uploadDataManagementMode) { public AddFileResponseBodyDataMode addFile(UploadDataManagementMode uploadDataManagementMode) {
AddFileRequest addFileRequest = new AddFileRequest(); AddFileRequest addFileRequest = AddFileRequest.builder()
RuntimeOptions runtime = new RuntimeOptions(); .workspaceId( uploadDataManagementMode.getWorkspaceId() )
Map<String, String> headers = new HashMap<>(); .regionId( uploadDataManagementMode.getLeaseId() )
.categoryId( uploadDataManagementMode.getLeaseId() )
.categoryType( uploadDataManagementMode.getCategoryType() )
.leaseId( uploadDataManagementMode.getLeaseId() )
.parser( uploadDataManagementMode.getParser() )
.tags( uploadDataManagementMode.getTags() )
.build();
String exceptionName = "";
try { try {
AddFileResponse addFileResponse = client.addFileWithOptions(uploadDataManagementMode.getWorkspaceId(), addFileRequest, headers, runtime); CompletableFuture<AddFileResponse> addFileResponse = client.addFile(addFileRequest);
if (addFileResponse.getStatusCode() != 200) { AddFileResponse addFileResponseget = addFileResponse.get();
throw new RuntimeException(addFileResponse.toString()); if (addFileResponseget.getStatusCode() != 200) {
throw new RuntimeException(addFileResponseget.toString());
} }
AddFileResponseBody body = addFileResponse.getBody(); AddFileResponseBody body = addFileResponseget.getBody();
AddFileResponseBody.AddFileResponseBodyData data = body.getData(); AddFileResponseBody.Data data = body.getData();
log.info("data:{}", data); log.info("data:{}", data);
return AddFileResponseBodyDataMode.builder() return AddFileResponseBodyDataMode.builder()
.fileId(data.getFileId()) .fileId(data.getFileId())

View File

@ -2,38 +2,47 @@ package com.muyu.aliyun.bailian;
import com.aliyun.bailian20231229.Client; import com.aliyun.bailian20231229.Client;
import com.aliyun.bailian20231229.models.*; import com.aliyun.bailian20231229.models.*;
import com.aliyun.sdk.service.bailian20231229.AsyncClient;
import com.aliyun.sdk.service.bailian20231229.models.DescribeFileRequest;
import com.aliyun.tea.*; import com.aliyun.tea.*;
import com.aliyun.teautil.models.RuntimeOptions; import com.aliyun.sdk.service.bailian20231229.models.DescribeFileResponse;
import com.muyu.aliyun.bailian.data.UploadDescribeFileMode; import com.muyu.aliyun.bailian.data.UploadDescribeFileMode;
import com.muyu.aliyun.bailian.data.fixed.DescribeFileResponseBodyDataMode; import com.muyu.aliyun.bailian.data.fixed.DescribeFileResponseBodyDataMode;
import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import com.aliyun.sdk.service.bailian20231229.models.DescribeFileResponseBody;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
import java.util.concurrent.CompletableFuture;
@Component @Component
@Log4j2 @Log4j2
public class ReviewResolution { public class ReviewResolution {
// @Autowired
private Client client; @Autowired
private AsyncClient client;
public DescribeFileResponseBodyDataMode DescribeFile(UploadDescribeFileMode uploadDescribeFileMode) { public DescribeFileResponseBodyDataMode DescribeFile(UploadDescribeFileMode uploadDescribeFileMode) {
RuntimeOptions runtime = new RuntimeOptions(); DescribeFileRequest describeFileRequest = DescribeFileRequest.builder()
Map<String, String> headers = new HashMap<>(); .workspaceId( uploadDescribeFileMode.getWorkspaceId() )
.regionId( uploadDescribeFileMode.getRegionId() )
.regionId( uploadDescribeFileMode.getFileId() )
.build();
try { try {
// 复制代码运行请自行打印 API 的返回值 // 复制代码运行请自行打印 API 的返回值
DescribeFileResponse describeFileResponse = client.describeFileWithOptions(uploadDescribeFileMode.getWorkspaceId(), uploadDescribeFileMode.getFileId(), headers, runtime); CompletableFuture<DescribeFileResponse> describeFileResponse = client.describeFile(describeFileRequest);
if (describeFileResponse.getStatusCode() == 200) { DescribeFileResponse describeFileResponseget = describeFileResponse.get();
if (describeFileResponseget.getStatusCode() == 200) {
log.info("文件信息获取成功"); log.info("文件信息获取成功");
} else { } else {
log.info("文件信息获取失败"); log.info("文件信息获取失败");
throw new RuntimeException(describeFileResponse.toString()); throw new RuntimeException(describeFileResponseget.toString());
} }
DescribeFileResponseBody body = describeFileResponse.getBody(); DescribeFileResponseBody body = describeFileResponseget.getBody();
DescribeFileResponseBody.DescribeFileResponseBodyData data = body.getData(); DescribeFileResponseBody.Data data = body.getData();
log.info("data:{}", data); log.info("data:{}", data);
return DescribeFileResponseBodyDataMode.builder() return DescribeFileResponseBodyDataMode.builder()
.categoryId(data.getCategoryId()) .categoryId(data.getCategoryId())

View File

@ -5,6 +5,8 @@ import lombok.Builder;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
import java.util.List;
@Data @Data
@Builder @Builder
@NoArgsConstructor @NoArgsConstructor
@ -16,12 +18,37 @@ public class UploadDataManagementMode {
* *
* 便 * 便
*/ */
private String WorkspaceId; private String workspaceId;
/** /**
* *
* *
* 便 * 便
*/ */
private String LeaseId; private String LeaseId;
/**
* ID
*/
private String regionId;
/**
* ID
*/
private String categoryId;
/**
*
*/
private String categoryType;
/**
* ID
*/
private String leaseId;
/**
*
*/
private String parser;
private List<String> tags;
} }

View File

@ -15,12 +15,19 @@ public class UploadDescribeFileMode {
* *
* 使 * 使
*/ */
private String WorkspaceId; private String workspaceId;
/** /**
* *
* 使 * 使
*/ */
private String FileId; private String fileId;
/**
* ID
*
*/
private String regionId;
} }