From 4d819cd1e612e41bfdfe05c8a71b2cd35d1a5e3a Mon Sep 17 00:00:00 2001 From: yaoxuwan Date: Wed, 31 Jul 2024 18:01:07 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=9E=84=E4=BB=B6=E4=BC=A0=E8=BE=93?= =?UTF-8?q?=E8=AE=B0=E5=BD=95=E6=8C=87=E6=A0=87=E5=A2=9E=E5=8A=A0userId=20?= =?UTF-8?q?#2448?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../artifact/event/listener/ArtifactTransferListener.kt | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/backend/common/common-artifact/artifact-service/src/main/kotlin/com/tencent/bkrepo/common/artifact/event/listener/ArtifactTransferListener.kt b/src/backend/common/common-artifact/artifact-service/src/main/kotlin/com/tencent/bkrepo/common/artifact/event/listener/ArtifactTransferListener.kt index 7355e69f73..b923f179d2 100644 --- a/src/backend/common/common-artifact/artifact-service/src/main/kotlin/com/tencent/bkrepo/common/artifact/event/listener/ArtifactTransferListener.kt +++ b/src/backend/common/common-artifact/artifact-service/src/main/kotlin/com/tencent/bkrepo/common/artifact/event/listener/ArtifactTransferListener.kt @@ -37,6 +37,7 @@ import com.tencent.bkrepo.common.artifact.constant.DEFAULT_STORAGE_KEY import com.tencent.bkrepo.common.artifact.event.ArtifactReceivedEvent import com.tencent.bkrepo.common.artifact.event.ArtifactResponseEvent import com.tencent.bkrepo.common.artifact.event.ChunkArtifactTransferEvent +import com.tencent.bkrepo.common.artifact.hash.md5 import com.tencent.bkrepo.common.artifact.metrics.ArtifactCacheMetrics import com.tencent.bkrepo.common.artifact.metrics.ArtifactMetrics import com.tencent.bkrepo.common.artifact.metrics.ArtifactMetricsProperties @@ -107,7 +108,7 @@ class ArtifactTransferListener( builderAgentList = artifactMetricsProperties.builderAgentList, clientAgentList = artifactMetricsProperties.clientAgentList ).name, - userId = SecurityUtils.getUserId() + userId = SecurityUtils.getUserId().md5() ) if (SecurityUtils.getUserId() != SYSTEM_USER) { projectUsageStatisticsService.inc(projectId = projectId, receivedBytes = throughput.bytes) @@ -153,7 +154,7 @@ class ArtifactTransferListener( builderAgentList = artifactMetricsProperties.builderAgentList, clientAgentList = artifactMetricsProperties.clientAgentList ).name, - userId = SecurityUtils.getUserId() + userId = SecurityUtils.getUserId().md5() ) if (SecurityUtils.getUserId() != SYSTEM_USER) { projectUsageStatisticsService.inc(projectId = projectId, responseBytes = throughput.bytes) @@ -210,7 +211,7 @@ class ArtifactTransferListener( builderAgentList = artifactMetricsProperties.builderAgentList, clientAgentList = artifactMetricsProperties.clientAgentList ).name, - userId = SecurityUtils.getUserId() + userId = SecurityUtils.getUserId().md5() ) if (artifactMetricsProperties.collectByLog) { logger.info(