From abb49f0fc74ba3ce1815e9ffcc33e2a6ce2a4777 Mon Sep 17 00:00:00 2001
From: mingshewhe <mingshewhe@tencent.com>
Date: Mon, 23 Oct 2023 12:01:30 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=90PAC=E3=80=91feat=EF=BC=9A=E6=94=AF?=
 =?UTF-8?q?=E6=8C=81=E4=BB=8E=E4=BB=A3=E7=A0=81=E5=BA=93=E7=BB=B4=E5=BA=A6?=
 =?UTF-8?q?=E6=9F=A5=E7=9C=8B=E5=AF=B9=E5=BA=94=E7=9A=84=E4=BB=A3=E7=A0=81?=
 =?UTF-8?q?=E5=BA=93=E4=BA=8B=E4=BB=B6=20#8122?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../misc/task/MigratePipelineDataTask.kt      | 34 -------------------
 1 file changed, 34 deletions(-)

diff --git a/src/backend/ci/core/misc/biz-misc/src/main/kotlin/com/tencent/devops/misc/task/MigratePipelineDataTask.kt b/src/backend/ci/core/misc/biz-misc/src/main/kotlin/com/tencent/devops/misc/task/MigratePipelineDataTask.kt
index b2075ea7642..87aa5c3afb7 100644
--- a/src/backend/ci/core/misc/biz-misc/src/main/kotlin/com/tencent/devops/misc/task/MigratePipelineDataTask.kt
+++ b/src/backend/ci/core/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,