feat auto update sdk

liyan.90210 · liyan.90210 · commit 901e685b2b12 · 2025-07-17T12:15:22.000Z
diff --git a/Changelog b/Changelog
@@ -1,5 +1,8 @@
 Change log
 
+2025-07-17 Bumped to version v1.0.229
+- Updated apis for tls/vikingDB
+
 2025-07-10 Bumped to version v1.0.228
 - Updated apis for imagex/livesaas/vikingDB/vms
 
diff --git a/volc-sdk-java/pom.xml b/volc-sdk-java/pom.xml
@@ -4,7 +4,7 @@
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.volcengine</groupId>
-    <version>1.0.228</version>
+    <version>1.0.229</version>
     <artifactId>volc-sdk-java</artifactId>
 
     <name>volc-sdk-java</name>
diff --git a/volc-sdk-java/src/main/java/com/volcengine/model/beans/livesaas/Tag.java b/volc-sdk-java/src/main/java/com/volcengine/model/beans/livesaas/Tag.java
@@ -0,0 +1,17 @@
+package com.volcengine.model.beans.livesaas;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+
+@Data
+public class Tag {
+    @JSONField(name = "TagId")
+    Long TagId;
+    @JSONField(name = "TagName")
+    String TagName;
+    @JSONField(name = "ParentTagId")
+    Long ParentTagId;
+    @JSONField(name = "ParentTagName")
+    String ParentTagName;
+}
diff --git a/volc-sdk-java/src/main/java/com/volcengine/model/livesaas/request/CreateTaskRequest.java b/volc-sdk-java/src/main/java/com/volcengine/model/livesaas/request/CreateTaskRequest.java
@@ -21,4 +21,10 @@ public class CreateTaskRequest {
     String CallbackURL;
     @JSONField(name = "Extra")
     String Extra;
+    @JSONField(name = "ActivityId")
+    Long ActivityId;
+    @JSONField(name = "TaskStartTime")
+    Long TaskStartTime;
+    @JSONField(name = "TagIds")
+    List<Long> TagIds;
 }
diff --git a/volc-sdk-java/src/main/java/com/volcengine/model/livesaas/request/GetPageWatchDataAPIV2Request.java b/volc-sdk-java/src/main/java/com/volcengine/model/livesaas/request/GetPageWatchDataAPIV2Request.java
@@ -11,4 +11,6 @@ public class GetPageWatchDataAPIV2Request {
     Long ActivityId;
     @JSONField(name = "PlayStatus")
     Integer PlayStatus;
+    @JSONField(name = "LineId")
+    Long LineId;
 }
diff --git a/volc-sdk-java/src/main/java/com/volcengine/model/livesaas/request/ListTasksRequest.java b/volc-sdk-java/src/main/java/com/volcengine/model/livesaas/request/ListTasksRequest.java
@@ -35,4 +35,6 @@ public class ListTasksRequest {
     List<Integer> manualStatus;
     @JSONField(name = "ActivityId")
     Long ActivityId;
+    @JSONField(name = "TagIds")
+    List<Long> TagIds;
 }
diff --git a/volc-sdk-java/src/main/java/com/volcengine/model/livesaas/response/GetMergedReportResponse.java b/volc-sdk-java/src/main/java/com/volcengine/model/livesaas/response/GetMergedReportResponse.java
@@ -1,6 +1,7 @@
 package com.volcengine.model.livesaas.response;
 
 import com.alibaba.fastjson.annotation.JSONField;
+import com.volcengine.model.beans.livesaas.Tag;
 import com.volcengine.model.response.ResponseMetadata;
 import lombok.Data;
 
@@ -67,8 +68,8 @@ public static class TaskResult {
         Integer Cost;
         @JSONField(name = "ManualEndTime")
         Long ManualEndTime;
-        @JSONField(name = "ASRResult")
-        List<ASRResult> ASRResult;
+        @JSONField(name = "ASRResults")
+        List<ASRResult> ASRResults;
         @JSONField(name = "RecordURLs")
         List<String> RecordURLs;
         @JSONField(name = "StatisticalData")
@@ -203,5 +204,9 @@ public static class TaskDetail {
         String CallbackURL;
         @JSONField(name = "Extra")
         String Extra;
+        @JSONField(name = "Tags")
+        List<Tag> Tags;
+        @JSONField(name = "ActivityId")
+        Long ActivityId;
     }
 }
diff --git a/volc-sdk-java/src/main/java/com/volcengine/model/livesaas/response/GetReportResponse.java b/volc-sdk-java/src/main/java/com/volcengine/model/livesaas/response/GetReportResponse.java
@@ -1,6 +1,7 @@
 package com.volcengine.model.livesaas.response;
 
 import com.alibaba.fastjson.annotation.JSONField;
+import com.volcengine.model.beans.livesaas.Tag;
 import com.volcengine.model.response.ResponseMetadata;
 import lombok.Data;
 
@@ -109,6 +110,46 @@ public static class MachineDetail {
         List<CustomSensitiveResult> CustomSensitiveResults;
         @JSONField(name = "SystemSensitiveResults")
         List<SystemSensitiveResult> SystemSensitiveResults;
+//        @JSONField(name = "OCRTextRecognitionResults")
+//        List<OCRTextRecognitionResult> OCRTextRecognitionResults;
+//        @JSONField(name = "OCRBottomSubtitleResults")
+//        List<SystemSensitiveResult> OCRBottomSubtitleResults;
+//        @JSONField(name = "PresetScriptResult")
+//        PresetScriptResult PresetScriptResult;
+    }
+
+    @Data
+    public static class OCRTextRecognitionResult {
+        @JSONField(name = "ImageURLs")
+        List<String> ImageURLs;
+        @JSONField(name = "AbsoluteStartTime")
+        Long AbsoluteStartTime;
+        @JSONField(name = "AbsoluteEndTime")
+        Long AbsoluteEndTime;
+        @JSONField(name = "Description")
+        String Description;
+    }
+
+    @Data
+    public static class OCRBottomSubtitleResult {
+        @JSONField(name = "ImageURLs")
+        List<String> ImageURLs;
+        @JSONField(name = "AbsoluteStartTime")
+        Long AbsoluteStartTime;
+        @JSONField(name = "AbsoluteEndTime")
+        Long AbsoluteEndTime;
+        @JSONField(name = "Description")
+        String Description;
+    }
+
+    @Data
+    public static class PresetScriptResult {
+        @JSONField(name = "ASRText")
+        String ASRText;
+        @JSONField(name = "ScriptSimilarity")
+        Integer ScriptSimilarity;
+        @JSONField(name = "PresetScriptText")
+        Integer PresetScriptText;
     }
 
     @Data
@@ -203,5 +244,9 @@ public static class TaskDetail {
         String CallbackURL;
         @JSONField(name = "Extra")
         String Extra;
+        @JSONField(name = "ActivityId")
+        Long ActivityId;
+        @JSONField(name = "Tags")
+        List<Tag> Tags;
     }
 }
diff --git a/volc-sdk-java/src/main/java/com/volcengine/model/livesaas/response/ListMediasAPIResponse.java b/volc-sdk-java/src/main/java/com/volcengine/model/livesaas/response/ListMediasAPIResponse.java
@@ -44,5 +44,9 @@ public static class ListMediasAPIForm {
         String Name;
         @JSONField(name = "SourceType")
         Integer SourceType;
+        @JSONField(name = "StartTime")
+        Long StartTime;
+        @JSONField(name = "EndTime")
+        Long EndTime;
     }
 }
diff --git a/volc-sdk-java/src/main/java/com/volcengine/model/livesaas/response/ListTasksResponse.java b/volc-sdk-java/src/main/java/com/volcengine/model/livesaas/response/ListTasksResponse.java
@@ -1,7 +1,7 @@
 package com.volcengine.model.livesaas.response;
 
 import com.alibaba.fastjson.annotation.JSONField;
-import com.volcengine.model.beans.livesaas.TaskDetail;
+import com.volcengine.model.beans.livesaas.Tag;
 import com.volcengine.model.response.ResponseMetadata;
 import lombok.Data;
 
@@ -54,5 +54,7 @@ public static class TaskDetail {
         String Extra;
         @JSONField(name = "ActivityId")
         Long ActivityId;
+        @JSONField(name = "Tags")
+        List<Tag> Tags;
     }
 }
diff --git a/volc-sdk-java/src/main/java/com/volcengine/model/tls/Const.java b/volc-sdk-java/src/main/java/com/volcengine/model/tls/Const.java
@@ -267,6 +267,9 @@ public class Const {
     public static final String X_TLS_HASHKEY = "x-tls-hashkey";
     public static final String X_TLS_COMPRESS_TYPE = "x-tls-compresstype";
     public static final String X_TLS_BODY_RAW_SIZE = "x-tls-bodyrawsize";
+    public static final String Log_Count_Header = "log-count";
+    public static final String Earliest_Log_Time_Header = "earliest-log-time";
+    public static final String Latest_Log_Time_Header = "latest-log-time";
     public static final String WEBHOOK = "Webhook";
     public static final String CONSUME_TOPIC = "ConsumeTopic";
     public static final String INTERVAL = "Interval";
diff --git a/volc-sdk-java/src/main/java/com/volcengine/service/tls/TLSLogClientImpl.java b/volc-sdk-java/src/main/java/com/volcengine/service/tls/TLSLogClientImpl.java
@@ -107,6 +107,38 @@ public PutLogsResponse putLogs(PutLogsRequest request) throws LogException {
             throw new LogException("InvalidArgument", "Invalid request, Please check it", null);
         }
 
+        int logCnt = 0;
+        long maxLogTime = Long.MIN_VALUE;
+        long minLogTime = Long.MAX_VALUE;
+
+        for (PutLogRequest.LogGroup logGroup : request.getLogGroupList().getLogGroupsList()) {
+            List<PutLogRequest.Log> logs = logGroup.getLogsList();
+            for (int i = 0; i < logs.size(); i++) {
+                PutLogRequest.Log log = logs.get(i);
+                long time = log.getTime();
+                long normalizedTime;
+                if (time <= 0) {
+                    time = System.currentTimeMillis();
+                    PutLogRequest.Log newLog = log.toBuilder().setTime(time).build();
+                    logs.set(i, newLog);
+                    normalizedTime = time;
+                } else if (time < 1e10) { // s
+                    normalizedTime = time * 1000;
+                } else if (time < 1e15) { // ms
+                    normalizedTime = time;
+                } else { // ns
+                    normalizedTime = time / 1_000_000;
+                }
+                maxLogTime = Math.max(maxLogTime, normalizedTime);
+                minLogTime = Math.min(minLogTime, normalizedTime);
+                logCnt++;
+            }
+        }
+
+        if (logCnt == 0) {
+            throw new LogException("InvalidArgument", "Invalid log num, Please check it", null);
+        }
+
         // 1、prepare request
         ArrayList<NameValuePair> params = new ArrayList<>();
         params.add(new BasicNameValuePair(TOPIC_ID, request.getTopicId()));
@@ -119,6 +151,11 @@ public PutLogsResponse putLogs(PutLogsRequest request) throws LogException {
             headers.put(X_TLS_COMPRESS_TYPE, compressType);
             headers.put(X_TLS_BODY_RAW_SIZE, String.valueOf(request.getLogGroupList().toByteArray().length));
         }
+
+        headers.put(Log_Count_Header, String.valueOf(logCnt));
+        headers.put(Earliest_Log_Time_Header, String.valueOf(minLogTime));
+        headers.put(Latest_Log_Time_Header, String.valueOf(maxLogTime));
+
         // 2、check sum and sendRequest
         RawResponse rawResponse = doProtoRetryRequest(PUT_LOGS, params, headers, request.getLogGroupList().toByteArray(), compressType);
         // 3、parse response
@@ -131,23 +168,21 @@ public PutLogsResponse putLogsV2(PutLogsRequestV2 request) throws LogException {
         if (request == null || StringUtils.isEmpty(request.getTopicId()) || request.getLogs() == null || request.getLogs().isEmpty()) {
             throw new LogException("InvalidArgument", "Request is:" + request, null);
         }
-        // 2、prepare request
-        ArrayList<NameValuePair> params = new ArrayList<>();
-        params.add(new BasicNameValuePair(TOPIC_ID, request.getTopicId()));
-        HashMap<String, String> headers = new HashMap<>();
-        if (request.getHashKey() != null) {
-            headers.put(X_TLS_HASHKEY, request.getHashKey());
-        }
-        PutLogRequest.LogGroupList logGroupList = AdaptorUtil.logItems2PbGroupList(request.getPath(), request.getSource(), request.getLogs());
-        String compressType = request.getCompressType();
-        if (compressType != null) {
-            headers.put(X_TLS_COMPRESS_TYPE, compressType);
-            headers.put(X_TLS_BODY_RAW_SIZE, String.valueOf(logGroupList.toByteArray().length));
-        }
-        // 3、check sum and sendRequest
-        RawResponse rawResponse = doProtoRetryRequest(PUT_LOGS, params, headers, logGroupList.toByteArray(), compressType);
-        // 4、parse response
-        return new PutLogsResponse(rawResponse.getHeaders());
+
+        PutLogsRequest putlogsRequest = new PutLogsRequest();
+        putlogsRequest.setTopicId(request.getTopicId());
+        putlogsRequest.setHashKey(request.getHashKey());
+        putlogsRequest.setCompressType(request.getCompressType());
+
+        PutLogRequest.LogGroupList logGroupList = AdaptorUtil.logItems2PbGroupList(
+            request.getPath(),
+            request.getSource(),
+            request.getLogs()
+        );
+
+        putlogsRequest.setLogGroupList(logGroupList);
+
+        return putLogs(putlogsRequest);
     }
 
     @Override
diff --git a/volc-sdk-java/src/main/java/com/volcengine/service/vikingDB/Index.java b/volc-sdk-java/src/main/java/com/volcengine/service/vikingDB/Index.java
@@ -204,6 +204,7 @@ public PageDataObject searchPagination(SearchParam searchParam) throws Exception
                       .setPrimaryKeyNotIn(searchParam.getPrimaryKeyNotIn())
                       .setPostProcessInputLimit(searchParam.getPostProcessInputLimit())
                       .setPostProcessOps(searchParam.getPostProcessOps())
+                      .setScaleK(searchParam.getScaleK())
                       .build();
               searchBody = searchByVectorParam.toMap();
           } else if (searchParam.getVectorOrder().getId() != null) {
@@ -218,6 +219,7 @@ public PageDataObject searchPagination(SearchParam searchParam) throws Exception
                       .setPrimaryKeyNotIn(searchParam.getPrimaryKeyNotIn())
                       .setPostProcessInputLimit(searchParam.getPostProcessInputLimit())
                       .setPostProcessOps(searchParam.getPostProcessOps())
+                      .setScaleK(searchParam.getScaleK())
                       .build();
                 searchBody = searchByIdParam.toMap();
           } else {
@@ -237,6 +239,7 @@ public PageDataObject searchPagination(SearchParam searchParam) throws Exception
             .setPrimaryKeyNotIn(searchParam.getPrimaryKeyNotIn())
             .setPostProcessInputLimit(searchParam.getPostProcessInputLimit())
             .setPostProcessOps(searchParam.getPostProcessOps())
+            .setScaleK(searchParam.getScaleK())
             .build();
             searchBody = multiModalParam.toMap();
       } else if (searchParam.getScalarOrder() != null) {
@@ -259,6 +262,8 @@ public PageDataObject searchPagination(SearchParam searchParam) throws Exception
               searchBody.put("output_fields", searchParam.getOutputFields());
           if (searchParam.getFilter() != null)
               searchBody.put("filter", searchParam.getFilter());
+          if (searchParam.getScaleK() != null)
+              searchBody.put("scale_k", searchParam.getScaleK());
           maybeSetPostProcessOps(searchParam, searchBody);
           maybeSetPrimaryKeyFilter(searchParam, searchBody);
       }
diff --git a/volc-sdk-java/src/main/java/com/volcengine/service/vikingDB/common/RawOrderParam.java b/volc-sdk-java/src/main/java/com/volcengine/service/vikingDB/common/RawOrderParam.java
@@ -7,4 +7,20 @@ public class RawOrderParam {
    private String image; // 或 String base64Image;
    private Boolean needInstruction;
    // 其他 SearchWithMultiModalParam 和 SearchByTextParam 共有的字段也可以考虑放在这里
+
+
+   public RawOrderParam setText(String text) {
+       this.text = text;
+       return this;
+   }
+
+   public RawOrderParam setImage(String image) {
+       this.image = image;
+       return this;
+   }
+
+   public RawOrderParam setNeedInstruction(Boolean needInstruction) {
+       this.needInstruction = needInstruction;
+       return this;
+   }
 }
diff --git a/volc-sdk-java/src/main/java/com/volcengine/service/vikingDB/common/SearchByIdParam.java b/volc-sdk-java/src/main/java/com/volcengine/service/vikingDB/common/SearchByIdParam.java
@@ -24,6 +24,12 @@ public class SearchByIdParam {
     private Integer isBuild = 0;
     private Boolean retry = false;
     private Boolean needReturnVector = false;
+    private Float scaleK = null;
+
+    public SearchByIdParam setScaleK(Float scaleK) {
+        this.scaleK = scaleK;
+        return this;
+    }
 
     public SearchByIdParam setId(Object id) {
         this.id = id;
@@ -114,6 +120,7 @@ public HashMap<String, Object> toMap() {
         if (outputFields != null) map.put("output_fields", outputFields);
         if (filter != null) map.put("filter", filter);
         if (denseWeight != null) map.put("dense_weight", denseWeight);
+        if (scaleK != null) map.put("scale_k", scaleK);
 
         return map;
     }
diff --git a/volc-sdk-java/src/main/java/com/volcengine/service/vikingDB/common/SearchByTextParam.java b/volc-sdk-java/src/main/java/com/volcengine/service/vikingDB/common/SearchByTextParam.java
@@ -23,6 +23,7 @@ public class SearchByTextParam {
     private Integer isBuild = 0;
     private Boolean retry = false;
     private Boolean needReturnVector = false;
+    private Float scaleK = null;
 
     public SearchByTextParam setText(Text text) {
         this.text = text;
@@ -138,6 +139,9 @@ public HashMap<String, Object> toMap() {
         if (this.getPostProcessOps() != null) {
             search.put("post_process_ops", this.getPostProcessOps());
         }
+        if (this.getScaleK() != null) {
+            search.put("scale_k", this.getScaleK());
+        }
         return search;
     }
 }
diff --git a/volc-sdk-java/src/main/java/com/volcengine/service/vikingDB/common/SearchByVectorParam.java b/volc-sdk-java/src/main/java/com/volcengine/service/vikingDB/common/SearchByVectorParam.java
diff --git a/volc-sdk-java/src/main/java/com/volcengine/service/vikingDB/common/SearchParam.java b/volc-sdk-java/src/main/java/com/volcengine/service/vikingDB/common/SearchParam.java
diff --git a/volc-sdk-java/src/main/java/com/volcengine/service/vikingDB/common/SearchWithMultiModalParam.java b/volc-sdk-java/src/main/java/com/volcengine/service/vikingDB/common/SearchWithMultiModalParam.java
diff --git a/volc-sdk-java/src/test/java/com/volcengine/service/tls/impl/LogsTest.java b/volc-sdk-java/src/test/java/com/volcengine/service/tls/impl/LogsTest.java

Original file line number	Diff line number	Diff line change
`@@ -11,4 +11,6 @@ public class GetPageWatchDataAPIV2Request {`
`11`	`11`	`Long ActivityId;`
`12`	`12`	`@JSONField(name = "PlayStatus")`
`13`	`13`	`Integer PlayStatus;`
	`14`	`+ @JSONField(name = "LineId")`
	`15`	`+ Long LineId;`
`14`	`16`	`}`
Original file line number	Diff line number	Diff line change
`@@ -35,4 +35,6 @@ public class ListTasksRequest {`
`35`	`35`	`List<Integer> manualStatus;`
`36`	`36`	`@JSONField(name = "ActivityId")`
`37`	`37`	`Long ActivityId;`
	`38`	`+ @JSONField(name = "TagIds")`
	`39`	`+ List<Long> TagIds;`
`38`	`40`	`}`
Original file line number	Diff line number	Diff line change
`@@ -44,5 +44,9 @@ public static class ListMediasAPIForm {`
`44`	`44`	`String Name;`
`45`	`45`	`@JSONField(name = "SourceType")`
`46`	`46`	`Integer SourceType;`
	`47`	`+ @JSONField(name = "StartTime")`
	`48`	`+ Long StartTime;`
	`49`	`+ @JSONField(name = "EndTime")`
	`50`	`+ Long EndTime;`
`47`	`51`	`}`
`48`	`52`	`}`
Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,7 @@`
`1`	`1`	`package com.volcengine.model.livesaas.response;`
`2`	`2`
`3`	`3`	`import com.alibaba.fastjson.annotation.JSONField;`
`4`		`-import com.volcengine.model.beans.livesaas.TaskDetail;`
	`4`	`+import com.volcengine.model.beans.livesaas.Tag;`
`5`	`5`	`import com.volcengine.model.response.ResponseMetadata;`
`6`	`6`	`import lombok.Data;`
`7`	`7`
`@@ -54,5 +54,7 @@ public static class TaskDetail {`
`54`	`54`	`String Extra;`
`55`	`55`	`@JSONField(name = "ActivityId")`
`56`	`56`	`Long ActivityId;`
	`57`	`+ @JSONField(name = "Tags")`
	`58`	`+ List<Tag> Tags;`
`57`	`59`	`}`
`58`	`60`	`}`