91 lines
3.2 KiB
Go
91 lines
3.2 KiB
Go
package repository
|
||
|
||
import (
|
||
"database/sql"
|
||
"fmt"
|
||
"log"
|
||
"sync"
|
||
"time"
|
||
|
||
"kfz-goods-pricing/internal/database"
|
||
)
|
||
|
||
// KfzConfig kfz_config 表结构
|
||
type KfzConfig struct {
|
||
ID int
|
||
NewPrice float64
|
||
PlaceholderDownPrice float64
|
||
MinShippingFee float64
|
||
MinPrice float64
|
||
QueryIndex int
|
||
}
|
||
|
||
var (
|
||
lastConfigLog time.Time
|
||
configLogMu sync.Mutex
|
||
)
|
||
|
||
// GetKfzConfig 获取 kfz_config 配置（ID=1）
|
||
// 无数据时返回 nil, nil
|
||
func GetKfzConfig() (*KfzConfig, error) {
|
||
var cfg KfzConfig
|
||
err := database.DB.QueryRow(
|
||
`SELECT id, new_price, placeholder_down_price, min_shipping_fee, min_price, query_index FROM kfz_config WHERE id=1`,
|
||
).Scan(&cfg.ID, &cfg.NewPrice, &cfg.PlaceholderDownPrice, &cfg.MinShippingFee, &cfg.MinPrice, &cfg.QueryIndex)
|
||
|
||
if err == sql.ErrNoRows {
|
||
log.Printf("[Repo/Config] kfz_config表无数据")
|
||
return nil, nil // 无数据
|
||
}
|
||
if err != nil {
|
||
log.Printf("[Repo/Config] 查询kfz_config失败: err=%v", err)
|
||
return nil, fmt.Errorf("查询kfz_config失败: %w", err)
|
||
}
|
||
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
|
||
}
|
||
|
||
// SaveKfzConfig 保存 kfz_config 配置
|
||
// 表中永远只有 ID=1 一条记录：无数据则 INSERT，有数据则 UPDATE
|
||
func SaveKfzConfig(cfg *KfzConfig) error {
|
||
var count int
|
||
err := database.DB.QueryRow("SELECT COUNT(*) FROM kfz_config").Scan(&count)
|
||
if err != nil {
|
||
log.Printf("[Repo/Config] 查询kfz_config数量失败: err=%v", err)
|
||
return fmt.Errorf("查询kfz_config失败: %w", err)
|
||
}
|
||
|
||
if count == 0 {
|
||
_, err = database.DB.Exec(
|
||
`INSERT INTO kfz_config (id, new_price, placeholder_down_price, min_shipping_fee, min_price, query_index) VALUES (1, ?, ?, ?, ?, ?)`,
|
||
cfg.NewPrice, cfg.PlaceholderDownPrice, cfg.MinShippingFee, cfg.MinPrice, cfg.QueryIndex,
|
||
)
|
||
if err != nil {
|
||
log.Printf("[Repo/Config] 插入配置失败: err=%v", err)
|
||
return 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)
|
||
} else {
|
||
_, err = database.DB.Exec(
|
||
`UPDATE kfz_config SET new_price=?, placeholder_down_price=?, min_shipping_fee=?, min_price=?, query_index=? WHERE id=1`,
|
||
cfg.NewPrice, cfg.PlaceholderDownPrice, cfg.MinShippingFee, cfg.MinPrice, cfg.QueryIndex,
|
||
)
|
||
if err != nil {
|
||
log.Printf("[Repo/Config] 更新配置失败: err=%v", err)
|
||
return 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)
|
||
}
|
||
return nil
|
||
}
|