(inlong) branch master updated: [INLONG-11391][Manager] Add openAPI for adding data add tasks (#11392)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git

The following commit(s) were added to refs/heads/master by this push:
     new 1bdc9e2497 [INLONG-11391][Manager] Add openAPI for adding data add 
tasks (#11392)
1bdc9e2497 is described below

commit 1bdc9e249738b16d5c8f9df4c70c8ef267e64adb
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Wed Oct 23 16:42:06 2024 +0800

    [INLONG-11391][Manager] Add openAPI for adding data add tasks (#11392)
---
 .../manager/client/api/inner/client/InlongGroupClient.java     | 10 ++++++++++
 .../inlong/manager/client/api/service/InlongGroupApi.java      |  3 +++
 .../web/controller/openapi/OpenStreamSourceController.java     |  8 ++++++++
 3 files changed, 21 insertions(+)

diff --git 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongGroupClient.java
 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongGroupClient.java
index fadc650e2d..e030d6ae99 100644
--- 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongGroupClient.java
+++ 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongGroupClient.java
@@ -298,6 +298,16 @@ public class InlongGroupClient {
         throw new RuntimeException(response.getErrMsg());
     }
 
+    public String getTenant(String groupId) {
+        Response<String> response = 
ClientUtils.executeHttpCall(inlongGroupApi.getTenant(groupId));
+        if (response.isSuccess()) {
+            return response.getData();
+        } else if (response.getErrMsg().contains("not exist")) {
+            return null;
+        }
+        throw new RuntimeException(response.getErrMsg());
+    }
+
     public List<InlongGroupTopicInfo> listTopics(InlongGroupTopicRequest 
request) {
         Response<List<InlongGroupTopicInfo>> response =
                 
ClientUtils.executeHttpCall(inlongGroupApi.listTopics(request));
diff --git 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/service/InlongGroupApi.java
 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/service/InlongGroupApi.java
index 4033765d0c..b421c12a60 100644
--- 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/service/InlongGroupApi.java
+++ 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/service/InlongGroupApi.java
@@ -88,6 +88,9 @@ public interface InlongGroupApi {
     @GET("group/countByStatus")
     Call<Response<Object>> countGroupByUser();
 
+    @GET("group/getTenant/{groupId}")
+    Call<Response<String>> getTenant(@Path("groupId") String groupId);
+
     @GET("group/getTopic/{id}")
     Call<Response<Object>> getTopic(@Path("id") String id);
 
diff --git 
a/inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/OpenStreamSourceController.java
 
b/inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/OpenStreamSourceController.java
index 1a7ad699f3..9785c3a26e 100644
--- 
a/inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/OpenStreamSourceController.java
+++ 
b/inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/OpenStreamSourceController.java
@@ -26,6 +26,7 @@ import 
org.apache.inlong.manager.common.validation.UpdateValidation;
 import org.apache.inlong.manager.pojo.common.BatchResult;
 import org.apache.inlong.manager.pojo.common.PageResult;
 import org.apache.inlong.manager.pojo.common.Response;
+import org.apache.inlong.manager.pojo.source.DataAddTaskRequest;
 import org.apache.inlong.manager.pojo.source.SourcePageRequest;
 import org.apache.inlong.manager.pojo.source.SourceRequest;
 import org.apache.inlong.manager.pojo.source.StreamSource;
@@ -129,4 +130,11 @@ public class OpenStreamSourceController {
         boolean result = sourceService.restart(id, 
LoginUserUtils.getLoginUser().getName());
         return Response.success(result);
     }
+
+    @RequestMapping(value = "/source/addDataAddTask", method = 
RequestMethod.POST)
+    @ApiOperation(value = "Add supplementary recording task for stream source")
+    public Response<List<Integer>> addSub(@RequestBody DataAddTaskRequest 
request) {
+        return Response.success(sourceService.addDataAddTask(request, 
LoginUserUtils.getLoginUser().getName()));
+    }
+
 }