From 6c1e0166728212eb1a7a243135cecafdd81fc3fd Mon Sep 17 00:00:00 2001 From: ShenQiLun <97694732@qq.com> Date: Tue, 30 Jun 2026 11:58:44 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E9=85=8D=E7=BD=AE=E6=9F=A5=E8=AF=A2?= =?UTF-8?q?=E6=97=A5=E5=BF=97=E6=94=B9=E4=B8=BA=E6=AF=8F10=E7=A7=92?= =?UTF-8?q?=E6=89=93=E5=8D=B0=E4=B8=80=E6=AC=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/repository/config_repository.go | 18 ++++++++++++++++-- 1 file changed, 16 insertions(+), 2 deletions(-) diff --git a/internal/repository/config_repository.go b/internal/repository/config_repository.go index f3a2d5b..336fabd 100644 --- a/internal/repository/config_repository.go +++ b/internal/repository/config_repository.go @@ -4,6 +4,8 @@ import ( "database/sql" "fmt" "log" + "sync" + "time" "kfz-goods-pricing/internal/database" ) @@ -18,6 +20,11 @@ type KfzConfig struct { QueryIndex int } +var ( + lastConfigLog time.Time + configLogMu sync.Mutex +) + // GetKfzConfig 获取 kfz_config 配置(ID=1) // 无数据时返回 nil, nil func GetKfzConfig() (*KfzConfig, error) { @@ -34,8 +41,15 @@ func GetKfzConfig() (*KfzConfig, error) { log.Printf("[Repo/Config] 查询kfz_config失败: err=%v", err) return nil, fmt.Errorf("查询kfz_config失败: %w", err) } - log.Printf("[Repo/Config] 查询成功: new_price=%.2f, placeholder_down_price=%.2f, min_shipping_fee=%.2f, min_price=%.2f, query_index=%d", - cfg.NewPrice, cfg.PlaceholderDownPrice, cfg.MinShippingFee, cfg.MinPrice, cfg.QueryIndex) + configLogMu.Lock() + if time.Since(lastConfigLog) > 10*time.Second { + lastConfigLog = time.Now() + configLogMu.Unlock() + log.Printf("[Repo/Config] 查询成功: new_price=%.2f, placeholder_down_price=%.2f, min_shipping_fee=%.2f, min_price=%.2f, query_index=%d", + cfg.NewPrice, cfg.PlaceholderDownPrice, cfg.MinShippingFee, cfg.MinPrice, cfg.QueryIndex) + } else { + configLogMu.Unlock() + } return &cfg, nil }