From 0c5908543a8679939754c0a4a168a133811f98bc Mon Sep 17 00:00:00 2001 From: ShenQiLun <97694732@qq.com> Date: Fri, 26 Jun 2026 17:17:13 +0800 Subject: [PATCH] =?UTF-8?q?refactor:=20=E7=A7=BB=E9=99=A4=E5=85=A8?= =?UTF-8?q?=E5=B1=80=E9=85=8D=E7=BD=AE=E5=92=8C=E6=9F=A5=E8=AF=A2=E6=88=90?= =?UTF-8?q?=E5=8A=9F=E5=90=8E=E7=9A=84=E8=AF=A6=E7=BB=86=E8=AE=A1=E7=AE=97?= =?UTF-8?q?=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/service/goods_service.go | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/internal/service/goods_service.go b/internal/service/goods_service.go index 53f45cb..e7b31e4 100644 --- a/internal/service/goods_service.go +++ b/internal/service/goods_service.go @@ -161,8 +161,6 @@ func (s *GoodsService) syncGoodsPricing() { log.Printf("[syncGoodsPricing] kfz_config表中无配置数据, 跳过本次同步。请到进销存系统中设置核价器配置") return } - log.Printf("[syncGoodsPricing] 全局配置: new_price=%.2f, placeholder_down_price=%.2f, min_shipping_fee=%.2f, min_price=%.2f, query_index=%d", - kfzConfig.NewPrice, kfzConfig.PlaceholderDownPrice, kfzConfig.MinShippingFee, kfzConfig.MinPrice, kfzConfig.QueryIndex) // 查询一条记录,按fail_count升序、updated_at倒序 record, err := s.goodsRepository.GetAllOrderByUpdatedAt() @@ -173,8 +171,6 @@ func (s *GoodsService) syncGoodsPricing() { if record == nil { return } - log.Printf("[syncGoodsPricing] 获取到待处理记录: id=%d, isbn=%s, book_name=%s, out_id=%s, fail_count=%d", - record.ID, record.ISBN, record.BookName, record.OutID, record.FailCount) // 限流等待 s.rateLimitWait() @@ -201,21 +197,14 @@ func (s *GoodsService) syncGoodsPricing() { price, _ = strconv.ParseFloat(bookInfo.Price, 64) shippingFee, _ = strconv.ParseFloat(bookInfo.ShippingFee, 64) totalPrice := price + shippingFee - log.Printf("[syncGoodsPricing] 孔网数据: id=%d, price=%.2f, shipping_fee=%.2f, total=%.2f", record.ID, price, shippingFee, totalPrice) - log.Printf("[syncGoodsPricing] 计算参数: placeholder_down_price=%.2f, min_shipping_fee=%.2f, kfzConfig.min_price=%.2f", - record.PlaceholderDownPrice, record.MinShippingFee, kfzConfig.MinPrice) finalPrice = totalPrice - record.PlaceholderDownPrice - record.MinShippingFee - log.Printf("[syncGoodsPricing] 减去占位降价和运费后: finalPrice=%.2f", finalPrice) if finalPrice < kfzConfig.MinPrice { - log.Printf("[syncGoodsPricing] 价格低于最低书价, 使用最低书价: %.2f -> %.2f", finalPrice, kfzConfig.MinPrice) finalPrice = kfzConfig.MinPrice } // 保留两位小数 - beforeRound := finalPrice finalPrice, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", finalPrice), 64) - log.Printf("[syncGoodsPricing] 最终价格取两位小数: %.2f -> %.2f", beforeRound, finalPrice) } if err := s.goodsRepository.UpdatePrice(record.ID, price, shippingFee, finalPrice); err != nil {