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 {