package goods_category_search

import (
	"ai_scheduler/internal/config"
	"ai_scheduler/internal/pkg/l_request"
	"ai_scheduler/internal/pkg/util"
	"context"
	"encoding/json"
	"fmt"
)

type Client struct {
	cfg config.ToolConfig
}

func New(cfg config.ToolConfig) *Client {
	return &Client{
		cfg: cfg,
	}
}

func (c *Client) Call(ctx context.Context, name string) (int, error) {
	if name == "" {
		return 0, nil
	}

	reqBody := GoodsCategorySearchRequest{
		Page:  1,
		Limit: 1,
		Search: SearchCondition{
			Name:  name,
			Level: 3, // 仅需三级分类
		},
	}

	apiReq, _ := util.StructToMap(reqBody)

	req := l_request.Request{
		Method: "Post",
		Url:    c.cfg.BaseURL,
		Json:   apiReq,
		Headers: map[string]string{
			"Content-Type": "application/json",
		},
	}

	res, err := req.Send()
	if err != nil {
		return 0, fmt.Errorf("请求失败，err: %v", err)
	}

	var resData GoodsCategorySearchResponse
	if err := json.Unmarshal([]byte(res.Text), &resData); err != nil {
		return 0, fmt.Errorf("解析响应失败，err: %v", err)
	}

	if resData.Code != 200 {
		return 0, fmt.Errorf("业务错误，code: %d, msg: %s", resData.Code, resData.Msg)
	}

	if len(resData.Data.List) == 0 {
		return 0, fmt.Errorf("商品分类不存在")
	}

	// 返回第一个匹配的分类ID
	return resData.Data.List[0].ID, nil
}
