XianYuApis-GO

// Demo 中选择选项 2，输入 Token 和 Cookie 即可

api, err := apis.QrcodeLogin(apis.QrcodeLoginConfig{
    PollInterval: 3 * time.Second,   // 轮询间隔
    Timeout:      120 * time.Second, // 超时时间
    ShowQR:       true,              // 终端打印二维码
})

cookies := map[string]string{
    "unb":       "123456789",
    "tracknick": "我的昵称",
    "_m_h5_tk":  "abcdef_1718000000000",
    "cookie2":   "xxxxxxxxxxxxxxxx",  // HttpOnly，必须从 Network 请求头复制
    "sgcookie":  "E100xxx...",         // HttpOnly，必须从 Network 请求头复制
}
api, err := apis.New(cookies, "")

ctx := context.Background()

// 获取 WebSocket 连接所需的 accessToken
token, err := api.GetToken(ctx)

// 刷新登录态（WebSocket 客户端已内置自动刷新）
err = api.RefreshToken(ctx)

itemInfo, err := api.GetItemInfo(ctx, "891198795482")
// 返回商品详情 JSON，包含 title、price、picList 等

result, err := api.UploadMedia(ctx, "./photo.png")
fmt.Printf("URL: %s, 尺寸: %dx%d\n", result.URL, result.Width, result.Height)

result, err := api.PublishItem(ctx,
    []string{"./product1.jpg", "./product2.jpg"},  // 本地图片路径
    "九成新机械键盘 自用半年 功能完好",               // 商品描述
    &model.Price{CurrentPrice: 299.0, OriginalPrice: 599.0},  // 价格
    model.DeliverySettings{Choice: "包邮"},         // 配送方式
)

// 适用于虚拟商品自动发货场景
result, err := api.ConfirmShipping(ctx, "订单ID")
// 成功时 ret 包含 "SUCCESS::调用成功"

// 从 API 客户端创建 WebSocket 客户端（共享登录态，推荐）
wsClient, err := ws.NewWithAPI(api)

// 设置消息处理回调
wsClient.SetMessageHandler(func(m *msg.Message) {
    switch {
    case m.IsText():
        fmt.Printf("[文字] %s(%s): %s\n", m.SenderName, m.SenderID, m.Content)
    case m.IsImage():
        fmt.Printf("[图片] %s(%s): %s (%dx%d)\n",
            m.SenderName, m.SenderID, m.ImageURL, m.ImageWidth, m.ImageHeight)
    }
})

// 启动 Token 自动刷新（默认 10 分钟，可自定义间隔）
wsClient.StartTokenRefresher()
wsClient.StartTokenRefresher(5 * time.Minute) // 自定义 5 分钟

// 建立连接（支持手动传入 Token，避免风控）
wsClient.ConnectWithToken(ctx, accessToken)

// 启动消息接收循环（阻塞）
wsClient.Start()

// 发送文字消息
wsClient.SendText(ctx, "conversation_id", "receiver_id", "你好")

// 发送图片消息（需先上传获取 URL）
uploadResult, _ := api.UploadMedia(ctx, "./photo.png")
wsClient.SendImage(ctx, "conversation_id", "receiver_id",
    uploadResult.URL, uploadResult.Width, uploadResult.Height)

// 检查连接是否存活
if !wsClient.IsAlive() {
    fmt.Println("连接断开，尝试重连...")
    wsClient.ConnectWithToken(ctx, "")
}

sigCtx, cancel := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGTERM)
defer cancel()
defer wsClient.Stop()

type Message struct {
    SenderID       string      // 发送者用户 ID
    SenderName     string      // 发送者昵称
    Content        string      // 消息文本内容
    MessageType    MessageType // 消息类型 (1=文字, 2=图片, 26=音频)
    ConversationID string      // 会话 ID
    ImageURL       string      // 图片 URL（仅图片消息，多图逗号分隔）
    ImageWidth     int         // 首张图片宽度
    ImageHeight    int         // 首张图片高度
    Timestamp      time.Time   // 消息时间
    Raw            any         // 原始数据（调试用）
}

// 签名生成: MD5(token + "&" + timestamp + "&" + appKey + "&" + data)
sign := util.GenerateSign(timestamp, token, data)

// 消息解密: base64 → 自定义 msgpack 解码 → JSON（整数键自动转字符串键）
decrypted, err := util.Decrypt(encryptedData)

// ID 生成
mid      := util.GenerateMid()              // 消息 ID
uuid     := util.GenerateUUID()             // 请求标识
deviceID := util.GenerateDeviceID("unb123") // 设备 ID

// Cookie 工具
cookies  := util.ParseCookies("key1=val1; key2=val2")  // 字符串 → map
cookieStr := util.BuildCookieString(cookies)            // map → 字符串

import "github.com/cv-cat/xianyuapis/pkg/open"

// 自研模式
client := open.NewClient("your_app_key", "your_app_secret")

// 商务对接模式
client := open.NewClient("app_key", "app_secret", open.WithSellerID("seller123"))

// 查询授权店铺列表
resp, err := client.User.GetAuthorizeList(ctx)
if resp.IsSuccess() {
    var list struct{ List []map[string]any `json:"list"` }
    resp.UnmarshalData(&list)
}

// 查询商品类目（普通商品/手机）
spBizType := open.SpBizTypeMobile
resp, _ := client.Good.GetProductCategoryList(ctx,
    open.ItemBizTypeCommon, &spBizType, nil)

// 查询商品列表（销售中）
saleStatus := open.SaleStatusOnSale
resp, _ = client.Good.GetProductList(ctx, &open.GetProductListRequest{
    SaleStatus: &saleStatus,
    PageNo:     1,
    PageSize:   20,
})

// 查询商品详情
resp, _ := client.Good.GetProductDetail(ctx, 1234567890)

// 创建商品（productData 为原始 map 或结构体）
resp, _ := client.Good.CreateProduct(ctx, map[string]any{
    "item_biz_type": open.ItemBizTypeCommon,
    "sp_biz_type":   open.SpBizTypeMobile,
    "channel_cat_id": "e11455b218c06e7ae10cfa39bf43dc0f",
    "price":          550000,  // 单位: 分
    "stock":          10,
    // ... 其他字段参考开放平台文档
})

// 上架商品
resp, _ := client.Good.ProductPublish(ctx, &open.ProductPublishRequest{
    ProductID: 220656347074629,
    UserName:  []string{"tb924343042"},
})

// 下架商品
resp, _ := client.Good.ProductDownShelf(ctx, 220656347074629)

// 编辑库存
stock := 99999
resp, _ := client.Good.ProductEditStock(ctx, &open.ProductEditStockRequest{
    ProductID: 219530767978565,
    Stock:     &stock,
})

// 删除商品
resp, _ := client.Good.ProductDelete(ctx, 219530767978565)

// 查询待发货订单
pendingShipment := open.OrderStatusPendingShipment
resp, _ := client.Order.GetOrderList(ctx, &open.GetOrderListRequest{
    OrderStatus: &pendingShipment,
    PageNo:      1,
    PageSize:    20,
})

// 查询订单详情
resp, _ := client.Order.GetOrderDetail(ctx, "1339920336328048683")

// 订单卡密列表
resp, _ := client.Order.KamOrderList(ctx, "1339920336328048683")

// 订单物流发货
districtID := int64(440305)
resp, _ := client.Order.OrderShip(ctx, &open.OrderShipRequest{
    OrderNo:        "1339920336328048683",
    WaybillNo:      "25051016899982",
    ExpressName:    "其他",
    ExpressCode:    "qita",
    ShipName:       "张三",
    ShipMobile:     "13800138000",
    ShipDistrictID: &districtID,
})

// 查询快递公司列表
resp, _ := client.Other.GetExpressCompanies(ctx)

// 商品类型
open.ItemBizTypeCommon        // 普通商品
open.ItemBizTypeInspectionBao // 验货宝
open.ItemBizTypeBrandAuth     // 品牌授权

// 行业类型
open.SpBizTypeMobile    // 手机
open.SpBizTypeDigital   // 3C数码
open.SpBizTypeLuxury    // 奢品

// 订单状态
open.OrderStatusPendingPayment     // 待付款
open.OrderStatusPendingShipment    // 待发货
open.OrderStatusShipped            // 已发货
open.OrderStatusTransactionSuccess // 交易成功

// 退款状态
open.RefundStatusSuccess      // 退款成功
open.RefundStatusRejected     // 已拒绝退款

import (
    "github.com/cv-cat/xianyuapis/pkg/apis"
    "github.com/cv-cat/xianyuapis/pkg/search"
)

// 1. 创建 API 实例（需登录 Cookie）
api, _ := apis.New(cookies, "")

// 2. 创建搜索爬虫
crawler := search.New(api)

// 3. 单页搜索
items, err := crawler.Search(ctx, &search.Request{
    Keyword:     "bebebus安全座椅",
    PageNumber:  1,
    RowsPerPage: 30,
})
for _, item := range items {
    fmt.Printf("%s | %s | %s\n", item.Title, item.SoldPrice, item.DetailURL)
}

// 4. 多页聚合搜索（最多 5 页）
items, err = crawler.SearchAll(ctx, &search.Request{
    Keyword: "机械键盘",
}, 5)

// 设置风控验证码处理回调
api.SetCaptchaHandler(func(verifyURL string) (string, error) {
    // 1. 打印验证链接给用户
    fmt.Printf("请在浏览器中打开: %s\n", verifyURL)
    // 2. 等待用户完成验证并粘贴新 Cookie
    newCookie := readLine()
    // 3. 返回新 Cookie，库会自动更新并重试
    return newCookie, nil
})