feat: 流水线级回调与流水线编排解耦 #11283

TencentBlueKing · Jan 15, 2025 · b71cac8 · b71cac8
1 parent 75326fc
commit b71cac8
Showing 1 changed file with 14 additions and 10 deletions.
diff --git a/...se/src/main/kotlin/com/tencent/devops/process/engine/service/PipelineRepositoryService.kt b/...se/src/main/kotlin/com/tencent/devops/process/engine/service/PipelineRepositoryService.kt
@@ -1379,20 +1379,24 @@ class PipelineRepositoryService constructor(
                 }
             }
         }
-        // 填充流水线级别回调
-        resource?.model?.events = pipelineCallbackDao.list(
+        pipelineCallbackDao.list(
             dslContext = dslContext,
             projectId = projectId,
             pipelineId = pipelineId,
             event = null
-        ).associate {
-            it.name to PipelineCallbackEvent(
-                callbackEvent = CallBackEvent.valueOf(it.eventType),
-                callbackUrl = it.url,
-                secretToken = it.secretToken?.let { AESUtil.decrypt(aesKey, it) },
-                region = CallBackNetWorkRegionType.valueOf(it.region),
-                callbackName = it.name
-            )
+        ).let { records ->
+            if (records.isNotEmpty) {
+                // 填充流水线级别回调
+                resource?.model?.events = records.associate {
+                    it.name to PipelineCallbackEvent(
+                        callbackEvent = CallBackEvent.valueOf(it.eventType),
+                        callbackUrl = it.url,
+                        secretToken = it.secretToken?.let { AESUtil.decrypt(aesKey, it) },
+                        region = CallBackNetWorkRegionType.valueOf(it.region),
+                        callbackName = it.name
+                    )
+                }
+            }
         }
         return resource
     }