发送 执行ID

src/org/qg/docker_new/StageBucketTke.groovy

@@ -96,7 +96,19 @@ def update_microservice(namespace, name, image, tier, domain) {
     def res_json = jsonParse(response.content)
     return res_json
 }
+def ding_talk(buildNumber,flag) {
+	dest_url = "http://192.168.29.80:3003/pipeline/dingTalk"
 
+    response = httpRequest httpMode:"POST",
+      consoleLogResponseBody:true,
+      contentType:"APPLICATION_JSON",
+      requestBody:"""{
+        "buildNumber":"${buildNumber}",
+        "flag":"${flag}",
+      }""",
+      url:dest_url
+
+}
 def set_image_info(microservice_name, git_commit_hash, image) {
 	dest_url = "http://eos.quantgroups.com/api/etcd/set_image_info"
 

vars/qgDockerPiplineWithDockerSlaveTke.groovy

@@ -88,9 +88,11 @@ def call(body) {
 				stage('Clean'){
 					_utils.beautyEcho("Clear Cache Tmp", "stage")
 					_stage.clean_images(imageTagInfos[0]["imageTag"],imageTagInfos[0]["imageTagCode"],contextDir,config.buildType)
+					_stage.ding_talk(buildNumber,"success")
 				}
 			} catch (err) {
 				_utils.beautyEcho(err, "fail")
+				_stage.ding_talk(buildNumber,"fail")
 				if(imageTagInfos != null){
 					_stage.clean_images(imageTagInfos[0]["imageTag"],imageTagInfos[0]["imageTagCode"],contextDir,config.buildType)
 				}