From a4ba3f1fa86ab2ad682c28f6e3ab0258099b4ac6 Mon Sep 17 00:00:00 2001 From: kercylan98 Date: Thu, 7 Sep 2023 20:01:14 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=20survey.Analyzer=20?= =?UTF-8?q?=E5=8E=BB=E9=87=8D=20BUG?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- utils/log/survey/analyzer.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/utils/log/survey/analyzer.go b/utils/log/survey/analyzer.go index b510965..e338cff 100644 --- a/utils/log/survey/analyzer.go +++ b/utils/log/survey/analyzer.go @@ -70,11 +70,12 @@ func (slf *Analyzer) IncreaseNonRepeat(key string, record R, recordKey string, d for _, v := range dimension { dvs = append(dvs, record.GetString(v)) } - dk := strings.Join(dvs, "_") + dk := strings.Join(append([]string{key}, dvs...), "_") if _, e := slf.repeat[dk]; e { slf.m.Unlock() return } + slf.repeat[dk] = struct{}{} slf.m.Unlock() slf.Increase(key, record, recordKey) } @@ -89,11 +90,12 @@ func (slf *Analyzer) IncreaseValueNonRepeat(key string, record R, value float64, for _, v := range dimension { dvs = append(dvs, record.GetString(v)) } - dk := strings.Join(dvs, "_") + dk := strings.Join(append([]string{key}, dvs...), "_") if _, e := slf.repeat[dk]; e { slf.m.Unlock() return } + slf.repeat[dk] = struct{}{} slf.m.Unlock() slf.IncreaseValue(key, value) }