DaShangDao/daShangDao_kfz_goods_pricing
8
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: 移除全局配置和查询成功后的详细计算日志

Browse Source
This commit is contained in:
ShenQiLun 2026-06-26 17:17:13 +08:00
parent 5d9a9afcce
commit 0c5908543a
1 changed files with 0 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
internal/service/goods_service.go
View File

@ -161,8 +161,6 @@ func (s *GoodsService) syncGoodsPricing() {
log.Printf("[syncGoodsPricing] kfz_config表中无配置数据, 跳过本次同步。请到进销存系统中设置核价器配置") log.Printf("[syncGoodsPricing] kfz_config表中无配置数据, 跳过本次同步。请到进销存系统中设置核价器配置")
return 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倒序 // 查询一条记录，按fail_count升序、updated_at倒序
record, err := s.goodsRepository.GetAllOrderByUpdatedAt() record, err := s.goodsRepository.GetAllOrderByUpdatedAt()
@ -173,8 +171,6 @@ func (s *GoodsService) syncGoodsPricing() {
if record == nil { if record == nil {
return 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() s.rateLimitWait()
@ -201,21 +197,14 @@ func (s *GoodsService) syncGoodsPricing() {
price, _ = strconv.ParseFloat(bookInfo.Price, 64) price, _ = strconv.ParseFloat(bookInfo.Price, 64)
shippingFee, _ = strconv.ParseFloat(bookInfo.ShippingFee, 64) shippingFee, _ = strconv.ParseFloat(bookInfo.ShippingFee, 64)
totalPrice := price + shippingFee 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 finalPrice = totalPrice - record.PlaceholderDownPrice - record.MinShippingFee
log.Printf("[syncGoodsPricing] 减去占位降价和运费后: finalPrice=%.2f", finalPrice)
if finalPrice < kfzConfig.MinPrice { if finalPrice < kfzConfig.MinPrice {
log.Printf("[syncGoodsPricing] 价格低于最低书价, 使用最低书价: %.2f -> %.2f", finalPrice, kfzConfig.MinPrice)
finalPrice = kfzConfig.MinPrice finalPrice = kfzConfig.MinPrice
} }
// 保留两位小数 // 保留两位小数
beforeRound := finalPrice
finalPrice, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", finalPrice), 64) 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 { if err := s.goodsRepository.UpdatePrice(record.ID, price, shippingFee, finalPrice); err != nil {