feat(http): support response codes

kevinlin09 · kevinlin09 · commit 26ce40864cfa · 2025-10-24T10:32:33.000+08:00
diff --git a/samples/GenerationStreamCall.java b/samples/GenerationStreamCall.java
@@ -18,21 +18,23 @@ public static void streamCall()
     Generation gen = new Generation();
     GenerationParam param = GenerationParam.builder()
             .model("qwen3-max")
-            .prompt("就当前的海洋污染的情况，写一份限塑的倡议书提纲，需要有理有据地号召大家克制地使用塑料制品")
+            .prompt("你好")
             .topP(0.8)
             .incrementalOutput(false)
             .build();
     Flowable<GenerationResult> result = gen.streamCall(param);
     result.blockingForEach(message -> {
-      System.out.println(JsonUtils.toJson(message));
+      System.out.println("generation_result:");
+      System.out.println(message);
+      System.out.println(JsonUtils.toJson(message) + "\n");
     });
   }
 
   public static void streamCallWithCallback()
       throws NoApiKeyException, ApiException, InputRequiredException,InterruptedException {
     Generation gen = new Generation();
     GenerationParam param = GenerationParam.builder().model(Generation.Models.QWEN_PLUS)
-        .prompt("就当前的海洋污染的情况，写一份限塑的倡议书提纲，需要有理有据地号召大家克制地使用塑料制品").topP(0.8).build();
+        .prompt("你好").topP(0.8).build();
     Semaphore semaphore = new Semaphore(0);
     gen.streamCall(param, new ResultCallback<GenerationResult>() {
 
@@ -86,17 +88,17 @@ public static void main(String[] args) {
       System.out.println(e.getMessage());
     }
 
-    try {
-      streamCallWithCallback();
-    } catch (ApiException | NoApiKeyException | InputRequiredException | InterruptedException e) {
-      System.out.println(e.getMessage());
-    }
-
-    try {
-      streamCallWithSearchOptions();
-    } catch (ApiException | NoApiKeyException | InputRequiredException e) {
-      System.out.println(e.getMessage());
-    }
+//    try {
+//      streamCallWithCallback();
+//    } catch (ApiException | NoApiKeyException | InputRequiredException | InterruptedException e) {
+//      System.out.println(e.getMessage());
+//    }
+//
+//    try {
+//      streamCallWithSearchOptions();
+//    } catch (ApiException | NoApiKeyException | InputRequiredException e) {
+//      System.out.println(e.getMessage());
+//    }
 
     System.exit(0);
   }
diff --git a/src/main/java/com/alibaba/dashscope/aigc/generation/GenerationResult.java b/src/main/java/com/alibaba/dashscope/aigc/generation/GenerationResult.java
@@ -4,6 +4,7 @@
 import com.alibaba.dashscope.common.DashScopeResult;
 import com.alibaba.dashscope.utils.JsonUtils;
 import com.google.gson.JsonObject;
+import com.google.gson.annotations.SerializedName;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 
@@ -13,12 +14,19 @@ public final class GenerationResult {
   private String requestId;
   private GenerationUsage usage;
   private GenerationOutput output;
+  @SerializedName("status_code")
+  private Integer statusCode;
+  private String code;
+  private String message;
 
   private GenerationResult() {}
 
   public static GenerationResult fromDashScopeResult(DashScopeResult dashScopeResult) {
     GenerationResult result = new GenerationResult();
     result.setRequestId(dashScopeResult.getRequestId());
+    result.setStatusCode(dashScopeResult.getStatusCode());
+    result.setCode(dashScopeResult.getCode());
+    result.setMessage(dashScopeResult.getMessage());
     if (dashScopeResult.getUsage() != null) {
       result.setUsage(
           JsonUtils.fromJsonObject(
diff --git a/src/main/java/com/alibaba/dashscope/aigc/imagesynthesis/ImageSynthesisListResult.java b/src/main/java/com/alibaba/dashscope/aigc/imagesynthesis/ImageSynthesisListResult.java
@@ -27,12 +27,22 @@ public class ImageSynthesisListResult {
   @SerializedName("page_size")
   private Integer pageSize;
 
+  @SerializedName("status_code")
+  private Integer statusCode;
+
+  private String code;
+
+  private String message;
+
   public static ImageSynthesisListResult fromDashScopeResult(DashScopeResult dashScopeResult) {
     if (dashScopeResult.getOutput() != null) {
       ImageSynthesisListResult rs =
           (JsonUtils.fromJsonObject(
               (JsonObject) dashScopeResult.getOutput(), ImageSynthesisListResult.class));
       rs.requestId = dashScopeResult.getRequestId();
+      rs.statusCode = dashScopeResult.getStatusCode();
+      rs.code = dashScopeResult.getCode();
+      rs.message = dashScopeResult.getMessage();
       return rs;
     } else {
       log.error(String.format("Result no output: %s", dashScopeResult));
diff --git a/src/main/java/com/alibaba/dashscope/aigc/imagesynthesis/ImageSynthesisResult.java b/src/main/java/com/alibaba/dashscope/aigc/imagesynthesis/ImageSynthesisResult.java
@@ -17,11 +17,21 @@ public class ImageSynthesisResult {
   private ImageSynthesisOutput output;
   private ImageSynthesisUsage usage;
 
+  @SerializedName("status_code")
+  private Integer statusCode;
+
+  private String code;
+
+  private String message;
+
   private ImageSynthesisResult() {}
 
   public static ImageSynthesisResult fromDashScopeResult(DashScopeResult dashScopeResult) {
     ImageSynthesisResult result = new ImageSynthesisResult();
     result.requestId = dashScopeResult.getRequestId();
+    result.statusCode = dashScopeResult.getStatusCode();
+    result.code = dashScopeResult.getCode();
+    result.message = dashScopeResult.getMessage();
     if (dashScopeResult.getUsage() != null) {
       result.setUsage(
           JsonUtils.fromJsonObject(
diff --git a/src/main/java/com/alibaba/dashscope/aigc/multimodalconversation/MultiModalConversationResult.java b/src/main/java/com/alibaba/dashscope/aigc/multimodalconversation/MultiModalConversationResult.java
@@ -3,6 +3,7 @@
 import com.alibaba.dashscope.common.DashScopeResult;
 import com.alibaba.dashscope.utils.JsonUtils;
 import com.google.gson.JsonObject;
+import com.google.gson.annotations.SerializedName;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 
@@ -13,11 +14,20 @@ public class MultiModalConversationResult {
   private MultiModalConversationUsage usage;
   private MultiModalConversationOutput output;
 
+  @SerializedName("status_code")
+  private Integer statusCode;
+
+  private String code;
+  private String message;
+
   private MultiModalConversationResult() {}
 
   public static MultiModalConversationResult fromDashScopeResult(DashScopeResult dashScopeResult) {
     MultiModalConversationResult result = new MultiModalConversationResult();
     result.setRequestId(dashScopeResult.getRequestId());
+    result.setStatusCode(dashScopeResult.getStatusCode());
+    result.setCode(dashScopeResult.getCode());
+    result.setMessage(dashScopeResult.getMessage());
     if (dashScopeResult.getUsage() != null) {
       result.setUsage(
           JsonUtils.fromJsonObject(
diff --git a/src/main/java/com/alibaba/dashscope/aigc/videosynthesis/VideoSynthesisListResult.java b/src/main/java/com/alibaba/dashscope/aigc/videosynthesis/VideoSynthesisListResult.java
@@ -27,12 +27,22 @@ public class VideoSynthesisListResult {
   @SerializedName("page_size")
   private Integer pageSize;
 
+  @SerializedName("status_code")
+  private Integer statusCode;
+
+  private String code;
+
+  private String message;
+
   public static VideoSynthesisListResult fromDashScopeResult(DashScopeResult dashScopeResult) {
     if (dashScopeResult.getOutput() != null) {
       VideoSynthesisListResult rs =
           (JsonUtils.fromJsonObject(
               (JsonObject) dashScopeResult.getOutput(), VideoSynthesisListResult.class));
       rs.requestId = dashScopeResult.getRequestId();
+      rs.statusCode = dashScopeResult.getStatusCode();
+      rs.code = dashScopeResult.getCode();
+      rs.message = dashScopeResult.getMessage();
       return rs;
     } else {
       log.error("Result no output: {}", dashScopeResult);
diff --git a/src/main/java/com/alibaba/dashscope/aigc/videosynthesis/VideoSynthesisResult.java b/src/main/java/com/alibaba/dashscope/aigc/videosynthesis/VideoSynthesisResult.java
@@ -17,11 +17,21 @@ public class VideoSynthesisResult {
   private VideoSynthesisOutput output;
   private VideoSynthesisUsage usage;
 
+  @SerializedName("status_code")
+  private Integer statusCode;
+
+  private String code;
+
+  private String message;
+
   private VideoSynthesisResult() {}
 
   public static VideoSynthesisResult fromDashScopeResult(DashScopeResult dashScopeResult) {
     VideoSynthesisResult result = new VideoSynthesisResult();
     result.requestId = dashScopeResult.getRequestId();
+    result.statusCode = dashScopeResult.getStatusCode();
+    result.code = dashScopeResult.getCode();
+    result.message = dashScopeResult.getMessage();
     if (dashScopeResult.getUsage() != null) {
       result.setUsage(
           JsonUtils.fromJsonObject(
diff --git a/src/main/java/com/alibaba/dashscope/app/ApplicationResult.java b/src/main/java/com/alibaba/dashscope/app/ApplicationResult.java
@@ -32,9 +32,24 @@ public class ApplicationResult {
   @SerializedName("usage")
   private ApplicationUsage usage;
 
+  /** HTTP status code from server response */
+  @SerializedName("status_code")
+  private Integer statusCode;
+
+  /** Error code from server response */
+  @SerializedName("code")
+  private String code;
+
+  /** Message from server response */
+  @SerializedName("message")
+  private String message;
+
   public static ApplicationResult fromDashScopeResult(DashScopeResult dashScopeResult) {
     ApplicationResult result = new ApplicationResult();
     result.setRequestId(dashScopeResult.getRequestId());
+    result.setStatusCode(dashScopeResult.getStatusCode());
+    result.setCode(dashScopeResult.getCode());
+    result.setMessage(dashScopeResult.getMessage());
     if (dashScopeResult.getUsage() != null) {
       result.setUsage(
           JsonUtils.fromJsonObject(
diff --git a/src/main/java/com/alibaba/dashscope/common/DashScopeResult.java b/src/main/java/com/alibaba/dashscope/common/DashScopeResult.java
@@ -57,6 +57,10 @@ protected <T extends Result> T fromResponse(Protocol protocol, NetworkResponse r
       }
     } else {
       JsonObject jsonObject = JsonUtils.parse(response.getMessage());
+      // Set HTTP status code if available
+      if (response.getHttpStatusCode() != null) {
+        this.setStatusCode(response.getHttpStatusCode());
+      }
       if (jsonObject.has(ApiKeywords.OUTPUT)) {
         this.output =
             jsonObject.get(ApiKeywords.OUTPUT).isJsonNull()
@@ -72,6 +76,30 @@ protected <T extends Result> T fromResponse(Protocol protocol, NetworkResponse r
       if (jsonObject.has(ApiKeywords.REQUEST_ID)) {
         this.setRequestId(jsonObject.get(ApiKeywords.REQUEST_ID).getAsString());
       }
+      if (jsonObject.has(ApiKeywords.STATUS_CODE)) {
+        this.setStatusCode(
+            jsonObject.get(ApiKeywords.STATUS_CODE).isJsonNull()
+                ? null
+                : jsonObject.get(ApiKeywords.STATUS_CODE).getAsInt());
+      }
+      if (jsonObject.has(ApiKeywords.CODE)) {
+        this.setCode(
+            jsonObject.get(ApiKeywords.CODE).isJsonNull()
+                ? ""
+                : jsonObject.get(ApiKeywords.CODE).getAsString());
+      } else {
+        // Set default empty string for successful responses
+        this.setCode("");
+      }
+      if (jsonObject.has(ApiKeywords.MESSAGE)) {
+        this.setMessage(
+            jsonObject.get(ApiKeywords.MESSAGE).isJsonNull()
+                ? ""
+                : jsonObject.get(ApiKeywords.MESSAGE).getAsString());
+      } else {
+        // Set default empty string for successful responses
+        this.setMessage("");
+      }
       if (jsonObject.has(ApiKeywords.DATA)) {
         if (jsonObject.has(ApiKeywords.REQUEST_ID)) {
           jsonObject.remove(ApiKeywords.REQUEST_ID);
@@ -116,6 +144,10 @@ public <T extends Result> T fromResponse(
     if ((response.getHeaders().containsKey("X-DashScope-OutputEncrypted".toLowerCase())
             || req.isEncryptRequest())
         && protocol == Protocol.HTTP) {
+      // Set HTTP status code if available
+      if (response.getHttpStatusCode() != null) {
+        this.setStatusCode(response.getHttpStatusCode());
+      }
       JsonObject jsonObject = JsonUtils.parse(response.getMessage());
       String encryptedOutput =
           jsonObject.get(ApiKeywords.OUTPUT).isJsonNull()
@@ -140,6 +172,30 @@ public <T extends Result> T fromResponse(
       if (jsonObject.has(ApiKeywords.REQUEST_ID)) {
         this.setRequestId(jsonObject.get(ApiKeywords.REQUEST_ID).getAsString());
       }
+      if (jsonObject.has(ApiKeywords.STATUS_CODE)) {
+        this.setStatusCode(
+            jsonObject.get(ApiKeywords.STATUS_CODE).isJsonNull()
+                ? null
+                : jsonObject.get(ApiKeywords.STATUS_CODE).getAsInt());
+      }
+      if (jsonObject.has(ApiKeywords.CODE)) {
+        this.setCode(
+            jsonObject.get(ApiKeywords.CODE).isJsonNull()
+                ? ""
+                : jsonObject.get(ApiKeywords.CODE).getAsString());
+      } else {
+        // Set default empty string for successful responses
+        this.setCode("");
+      }
+      if (jsonObject.has(ApiKeywords.MESSAGE)) {
+        this.setMessage(
+            jsonObject.get(ApiKeywords.MESSAGE).isJsonNull()
+                ? ""
+                : jsonObject.get(ApiKeywords.MESSAGE).getAsString());
+      } else {
+        // Set default empty string for successful responses
+        this.setMessage("");
+      }
       if (jsonObject.has(ApiKeywords.DATA)) {
         if (jsonObject.has(ApiKeywords.REQUEST_ID)) {
           jsonObject.remove(ApiKeywords.REQUEST_ID);
diff --git a/src/main/java/com/alibaba/dashscope/common/Result.java b/src/main/java/com/alibaba/dashscope/common/Result.java
@@ -26,6 +26,15 @@ public abstract class Result {
   /** The headers of response */
   private Map<String, String> headers;
 
+  /** The HTTP status code from server response */
+  private Integer statusCode;
+
+  /** The error code from server response */
+  private String code;
+
+  /** The message from server response */
+  private String message;
+
   /**
    * Load data from the server output.
    *
diff --git a/src/main/java/com/alibaba/dashscope/embeddings/BatchTextEmbeddingResult.java b/src/main/java/com/alibaba/dashscope/embeddings/BatchTextEmbeddingResult.java
@@ -16,6 +16,13 @@ public class BatchTextEmbeddingResult {
   private BatchTextEmbeddingOutput output;
   private BatchTextEmbeddingUsage usage;
 
+  @SerializedName("status_code")
+  private Integer statusCode;
+
+  private String code;
+
+  private String message;
+
   private BatchTextEmbeddingResult() {}
 
   public static BatchTextEmbeddingResult fromDashScopeResult(DashScopeResult dashScopeResult) {
@@ -25,6 +32,9 @@ public static BatchTextEmbeddingResult fromDashScopeResult(DashScopeResult dashS
             (JsonObject) dashScopeResult.getOutput(), BatchTextEmbeddingOutput.class);
     res.usage = JsonUtils.fromJson(dashScopeResult.getUsage(), BatchTextEmbeddingUsage.class);
     res.requestId = dashScopeResult.getRequestId();
+    res.statusCode = dashScopeResult.getStatusCode();
+    res.code = dashScopeResult.getCode();
+    res.message = dashScopeResult.getMessage();
     return res;
   }
 }
diff --git a/src/main/java/com/alibaba/dashscope/embeddings/MultiModalEmbeddingResult.java b/src/main/java/com/alibaba/dashscope/embeddings/MultiModalEmbeddingResult.java
@@ -5,6 +5,7 @@
 import com.alibaba.dashscope.common.DashScopeResult;
 import com.alibaba.dashscope.utils.JsonUtils;
 import com.google.gson.JsonObject;
+import com.google.gson.annotations.SerializedName;
 import lombok.Data;
 
 @Data
@@ -13,6 +14,12 @@ public class MultiModalEmbeddingResult {
   private MultiModalEmbeddingOutput output;
   private MultiModalEmbeddingUsage usage;
 
+  @SerializedName("status_code")
+  private Integer statusCode;
+
+  private String code;
+  private String message;
+
   private MultiModalEmbeddingResult() {}
 
   public static MultiModalEmbeddingResult fromDashScopeResult(DashScopeResult dashScopeResult) {
@@ -23,6 +30,9 @@ public static MultiModalEmbeddingResult fromDashScopeResult(DashScopeResult dash
     res.usage =
         JsonUtils.fromJson((JsonObject) dashScopeResult.getUsage(), MultiModalEmbeddingUsage.class);
     res.requestId = dashScopeResult.getRequestId();
+    res.statusCode = dashScopeResult.getStatusCode();
+    res.code = dashScopeResult.getCode();
+    res.message = dashScopeResult.getMessage();
     return res;
   }
 }
diff --git a/src/main/java/com/alibaba/dashscope/embeddings/TextEmbeddingResult.java b/src/main/java/com/alibaba/dashscope/embeddings/TextEmbeddingResult.java
diff --git a/src/main/java/com/alibaba/dashscope/protocol/NetworkResponse.java b/src/main/java/com/alibaba/dashscope/protocol/NetworkResponse.java
diff --git a/src/main/java/com/alibaba/dashscope/protocol/okhttp/OkHttpHttpClient.java b/src/main/java/com/alibaba/dashscope/protocol/okhttp/OkHttpHttpClient.java
diff --git a/src/main/java/com/alibaba/dashscope/rerank/TextReRankResult.java b/src/main/java/com/alibaba/dashscope/rerank/TextReRankResult.java
diff --git a/src/main/java/com/alibaba/dashscope/task/AsyncTaskListResult.java b/src/main/java/com/alibaba/dashscope/task/AsyncTaskListResult.java
diff --git a/src/main/java/com/alibaba/dashscope/utils/ApiKeywords.java b/src/main/java/com/alibaba/dashscope/utils/ApiKeywords.java
