diff --git a/src/backend/ci/core/auth/biz-auth-rbac/src/main/kotlin/com/tencent/devops/auth/service/migrate/RbacPermissionMigrateService.kt b/src/backend/ci/core/auth/biz-auth-rbac/src/main/kotlin/com/tencent/devops/auth/service/migrate/RbacPermissionMigrateService.kt index 6e8edd170b0..c608e6c99b2 100644 --- a/src/backend/ci/core/auth/biz-auth-rbac/src/main/kotlin/com/tencent/devops/auth/service/migrate/RbacPermissionMigrateService.kt +++ b/src/backend/ci/core/auth/biz-auth-rbac/src/main/kotlin/com/tencent/devops/auth/service/migrate/RbacPermissionMigrateService.kt @@ -80,6 +80,7 @@ class RbacPermissionMigrateService constructor( private const val ALL_MEMBERS_NAME = "allMembersName" private val toRbacExecutorService = Executors.newFixedThreadPool(5) private val migrateProjectsExecutorService = Executors.newFixedThreadPool(5) + private val migrateMonitorExecutorService = Executors.newFixedThreadPool(5) } @Value("\${auth.migrateProjectTag:#{null}}") @@ -177,13 +178,17 @@ class RbacPermissionMigrateService constructor( override fun migrateMonitorResource(projectCodes: List): Boolean { projectCodes.filter { - // 仅迁移 迁移成功的项目 + // 仅迁移"迁移成功"的项目 authMigrationDao.get( dslContext = dslContext, projectCode = it )?.status == AuthMigrateStatus.SUCCEED.value }.map { - migrateResourceService.migrateMonitorResource(projectCode = it) + val traceId = MDC.get(TraceTag.BIZID) + migrateMonitorExecutorService.submit{ + MDC.put(TraceTag.BIZID, traceId) + migrateResourceService.migrateMonitorResource(projectCode = it) + } } return true }