fix: 修复重复增加ddc blob引用数 #2825

TencentBlueKing · Dec 9, 2024 · 1ce1bbb · 1ce1bbb
1 parent 86fd46e
commit 1ce1bbb
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/backend/ddc/biz-ddc/src/main/kotlin/com/tencent/bkrepo/ddc/service/BlobService.kt b/src/backend/ddc/biz-ddc/src/main/kotlin/com/tencent/bkrepo/ddc/service/BlobService.kt
@@ -111,14 +111,18 @@ class BlobService(
     fun addRefToBlobs(ref: Reference, blobIds: Set<String>) {
         with(ref) {
             val addedBlobIds = blobRefRepository.addRefToBlob(projectId, repoName, bucket, key.toString(), blobIds)
-            blobRepository.incRefCount(projectId, repoName, addedBlobIds)
+            if (addedBlobIds.isNotEmpty()) {
+                blobRepository.incRefCount(projectId, repoName, addedBlobIds)
+            }
         }
     }
 
     fun removeRefFromBlobs(projectId: String, repoName: String, bucket: String, key: String) {
         val blobIds = HashSet<String>()
         blobRefRepository.removeRefFromBlob(projectId, repoName, bucket, key).mapTo(blobIds) { it.blobId }
-        blobRepository.incRefCount(projectId, repoName, blobIds, -1L)
+        if (blobIds.isNotEmpty()) {
+            blobRepository.incRefCount(projectId, repoName, blobIds, -1L)
+        }
         // 兼容旧逻辑，所有blob的references字段为空后可以移除该逻辑
         blobRepository.removeRefFromBlob(projectId, repoName, bucket, key)
     }