98 lines
2.4 KiB
Go
98 lines
2.4 KiB
Go
package handler
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"log"
|
|
"net/http"
|
|
"strconv"
|
|
"sync"
|
|
|
|
"kfz-goods-pricing/internal/config"
|
|
)
|
|
|
|
// ConfigHandler 配置处理器
|
|
type ConfigHandler struct {
|
|
configPath string
|
|
mu sync.Mutex
|
|
}
|
|
|
|
// NewConfigHandler 创建配置处理器实例
|
|
func NewConfigHandler(configPath string) *ConfigHandler {
|
|
return &ConfigHandler{
|
|
configPath: configPath,
|
|
}
|
|
}
|
|
|
|
// GetConfigPrice 获取配置（价格相关）
|
|
func (h *ConfigHandler) GetConfigPrice(w http.ResponseWriter, r *http.Request) {
|
|
h.mu.Lock()
|
|
defer h.mu.Unlock()
|
|
|
|
cfg, err := config.Load(h.configPath)
|
|
if err != nil {
|
|
log.Printf("[GetConfigPrice] 读取配置失败: %s", err.Error())
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Write([]byte(fmt.Sprintf(`{"code":500,"message":"读取配置失败: %s"}`, err.Error())))
|
|
return
|
|
}
|
|
|
|
w.Header().Set("Content-Type", "application/json")
|
|
json.NewEncoder(w).Encode(map[string]interface{}{
|
|
"code": 200,
|
|
"message": "success",
|
|
"data": cfg,
|
|
})
|
|
}
|
|
|
|
// SetConfigPrice 修改价格配置
|
|
func (h *ConfigHandler) SetConfigPrice(w http.ResponseWriter, r *http.Request) {
|
|
r.ParseMultipartForm(32 << 20)
|
|
|
|
newPrice := r.PostForm.Get("new_price")
|
|
if newPrice == "" {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Write([]byte(`{"code":400,"message":"new_price不能为空"}`))
|
|
return
|
|
}
|
|
|
|
val := 0.0
|
|
val, _ = strconv.ParseFloat(newPrice, 64)
|
|
if val < 0 {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Write([]byte(`{"code":400,"message":"new_price必须大于0"}`))
|
|
return
|
|
}
|
|
|
|
h.mu.Lock()
|
|
defer h.mu.Unlock()
|
|
|
|
cfg, err := config.Load(h.configPath)
|
|
if err != nil {
|
|
log.Printf("[SetConfigPrice] 读取配置失败: %s", err.Error())
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Write([]byte(fmt.Sprintf(`{"code":500,"message":"读取配置失败: %s"}`, err.Error())))
|
|
return
|
|
}
|
|
|
|
cfg.NewPrice = val
|
|
|
|
if err := config.Save(h.configPath, cfg); err != nil {
|
|
log.Printf("[SetConfigPrice] 保存配置失败: %s", err.Error())
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Write([]byte(fmt.Sprintf(`{"code":500,"message":"保存配置失败: %s"}`, err.Error())))
|
|
return
|
|
}
|
|
|
|
// 同步全局配置
|
|
config.SetGlobal(cfg)
|
|
log.Printf("[SetConfigPrice] 配置更新成功: new_price=%.2f", cfg.NewPrice)
|
|
|
|
w.Header().Set("Content-Type", "application/json")
|
|
json.NewEncoder(w).Encode(map[string]interface{}{
|
|
"code": 200,
|
|
"message": "success",
|
|
"data": cfg,
|
|
})
|
|
}
|