【PAC】feat：支持从代码库维度查看对应的代码库事件 #8122

TencentBlueKing · Oct 23, 2023 · abb49f0 · abb49f0
1 parent 8cc764c
commit abb49f0
Showing 1 changed file with 0 additions and 34 deletions.
diff --git a/...ore/misc/biz-misc/src/main/kotlin/com/tencent/devops/misc/task/MigratePipelineDataTask.kt b/...ore/misc/biz-misc/src/main/kotlin/com/tencent/devops/misc/task/MigratePipelineDataTask.kt
@@ -166,14 +166,6 @@ class MigratePipelineDataTask constructor(
                     migratingShardingDslContext = migratingShardingDslContext,
                     processDataMigrateDao = processDbMigrateDao
                 )
-                // 3.14、迁移T_PIPELINE_WEBHOOK_BUILD_LOG_DETAIL表数据
-                migratePipelineWebhookBuildLogDetailData(
-                    projectId = projectId,
-                    pipelineId = pipelineId,
-                    dslContext = dslContext,
-                    migratingShardingDslContext = migratingShardingDslContext,
-                    processDataMigrateDao = processDbMigrateDao
-                )
                 // 3.15、迁移T_PIPELINE_WEBHOOK_QUEUE表数据
                 migratePipelineWebhookQueueData(
                     projectId = projectId,
@@ -597,32 +589,6 @@ class MigratePipelineDataTask constructor(
         } while (pipelineSettingVersionRecords.size == SHORT_PAGE_SIZE)
     }
 
-    private fun migratePipelineWebhookBuildLogDetailData(
-        projectId: String,
-        pipelineId: String,
-        dslContext: DSLContext,
-        migratingShardingDslContext: DSLContext,
-        processDataMigrateDao: ProcessDataMigrateDao
-    ) {
-        var offset = 0
-        do {
-            val webhookBuildLogDetailRecords = processDataMigrateDao.getPipelineWebhookBuildLogDetailRecords(
-                dslContext = dslContext,
-                projectId = projectId,
-                pipelineId = pipelineId,
-                limit = SHORT_PAGE_SIZE,
-                offset = offset
-            )
-            if (webhookBuildLogDetailRecords.isNotEmpty()) {
-                processDataMigrateDao.migratePipelineWebhookBuildLogDetailData(
-                    migratingShardingDslContext = migratingShardingDslContext,
-                    webhookBuildLogDetailRecords = webhookBuildLogDetailRecords
-                )
-            }
-            offset += SHORT_PAGE_SIZE
-        } while (webhookBuildLogDetailRecords.size == SHORT_PAGE_SIZE)
-    }
-
     private fun migratePipelineWebhookQueueData(
         projectId: String,
         pipelineId: String,