From 2b7ffe4d62b6cb5119dbd857fda9137dd7e7afce Mon Sep 17 00:00:00 2001
From: user <8352767+zhegu123@user.noreply.gitee.com>
Date: Mon, 22 May 2023 15:40:16 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E8=8E=B7=E5=8F=96=E6=B5=81?=
 =?UTF-8?q?=E6=B0=B4=E7=BA=BF=E7=8A=B6=E6=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pom.xml                                       | 29 ++++++++++++++
 .../CodeArtsPipelineService.java              | 38 ++++++++++++++++---
 2 files changed, 61 insertions(+), 6 deletions(-)

diff --git a/pom.xml b/pom.xml
index cc3a31d..b133075 100644
--- a/pom.xml
+++ b/pom.xml
@@ -218,6 +218,35 @@
             </exclusions>
         </dependency>
 
+
+        <dependency>
+            <groupId>com.huaweicloud.sdk</groupId>
+            <artifactId>huaweicloud-sdk-cloudtest</artifactId>
+            <version>3.1.39</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>com.fasterxml.jackson.core</groupId>
+                    <artifactId>jackson-core</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>com.fasterxml.jackson.core</groupId>
+                    <artifactId>jackson-databind</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>com.huaweicloud.sdk</groupId>
+                    <artifactId>huaweicloud-sdk-core</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>org.openeuler</groupId>
+                    <artifactId>bgmprovider</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>org.slf4j</groupId>
+                    <artifactId>slf4j-api</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+
     </dependencies>
 
     <repositories>
diff --git a/src/main/java/com/huawei/jenkins/cloudpipeline/CodeArtsPipelineService.java b/src/main/java/com/huawei/jenkins/cloudpipeline/CodeArtsPipelineService.java
index 2d9af92..152c771 100644
--- a/src/main/java/com/huawei/jenkins/cloudpipeline/CodeArtsPipelineService.java
+++ b/src/main/java/com/huawei/jenkins/cloudpipeline/CodeArtsPipelineService.java
@@ -2,9 +2,7 @@ package com.huawei.jenkins.cloudpipeline;
 
 import com.google.common.base.Preconditions;
 import com.huaweicloud.sdk.cloudpipeline.v2.CloudPipelineClient;
-import com.huaweicloud.sdk.cloudpipeline.v2.model.RunPipelineDTO;
-import com.huaweicloud.sdk.cloudpipeline.v2.model.RunPipelineRequest;
-import com.huaweicloud.sdk.cloudpipeline.v2.model.RunPipelineResponse;
+import com.huaweicloud.sdk.cloudpipeline.v2.model.*;
 import com.huaweicloud.sdk.cloudpipeline.v2.region.CloudPipelineRegion;
 import com.huaweicloud.sdk.core.auth.BasicCredentials;
 import com.huaweicloud.sdk.core.auth.ICredential;
@@ -35,10 +33,17 @@ public class CodeArtsPipelineService implements Serializable {
         request.withPipelineId(customInput.getPipeline_id());
         RunPipelineDTO body = new RunPipelineDTO();
         request.withBody(body);
-        String message = "";
+        String status = "RUNNING";
         try {
             RunPipelineResponse response = client.runPipeline(request);
-            message = response.getPipelineRunId();
+            while (status.equals("RUNNING")) {
+                status = ShowPipelineRunDetail(client, listener, customInput);
+                try {
+                    Thread.currentThread().sleep(10000);
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+            }
         } catch (ConnectionException e) {
             e.printStackTrace();
         } catch (RequestTimeoutException e) {
@@ -47,7 +52,28 @@ public class CodeArtsPipelineService implements Serializable {
             e.printStackTrace();
             listener.getLogger().println("ErrorMsg：" + e.getErrorMsg());
         }
-        return message;
+        return status;
+    }
+
+
+    public static String ShowPipelineRunDetail(CloudPipelineClient client, TaskListener listener, CustomInput customInput) {
+        ShowPipelineRunDetailRequest request = new ShowPipelineRunDetailRequest();
+        request.withProjectId(customInput.getProject_id());
+        request.withPipelineId(customInput.getPipeline_id());
+        String status = "RUNNING";
+        try {
+            ShowPipelineRunDetailResponse response = client.showPipelineRunDetail(request);
+            status = response.getStatus();
+            listener.getLogger().println("status：" + response.getStatus());
+        } catch (ConnectionException e) {
+            e.printStackTrace();
+        } catch (RequestTimeoutException e) {
+            e.printStackTrace();
+        } catch (ServiceResponseException e) {
+            e.printStackTrace();
+            listener.getLogger().println("ErrorMsg：" + e.getErrorMsg());
+        }
+        return status;
     }
 
     private static void inputValidate(CustomInput customInput) {
-- 
Gitee