Compare commits
8 Commits
Author | SHA1 | Date | |
---|---|---|---|
![]() |
58cf9d920d | ||
![]() |
fa19e791e0 | ||
![]() |
af3360113d | ||
![]() |
be569bda75 | ||
![]() |
160d955a0c | ||
![]() |
96c87f015d | ||
![]() |
c5b73fb675 | ||
![]() |
7ddebe6fc3 |
47
weipinshang_api/req.go
Normal file
47
weipinshang_api/req.go
Normal file
@@ -0,0 +1,47 @@
|
||||
package weipinshang_api
|
||||
|
||||
type CreateAfsApplyReq struct {
|
||||
McOrderNo int `json:"mcOrderNo"` // 子订单号 是 int 下单时候返回子订单号 20190704124955600363
|
||||
CustomerExpect int `json:"customerExpect"` // 售后类型 是 int [退货(10)、仅退款(40)] 10
|
||||
QuestionDesc string `json:"questionDesc"` // 原因描述 否 String [产品问题描述,最多600字符] 看下面请求示例
|
||||
QuestionPic string `json:"questionPic"` //问题描述图片 否 String [问题描述图片.最多2000字符] 支持多张图片,用逗号分隔(英文逗号)
|
||||
CustomerContactName string `json:"customerContactName"` // 用户姓名 是 String [用户姓名] 张三
|
||||
CustomerTel string `json:"customerTel"` // 用户电话 是 String [用户电话] 18533136240
|
||||
CustomerMobilePhone string `json:"customerMobilePhone"` // 用户手机 是 String [用户手机] 18533136240
|
||||
PickwareProvince string `json:"pickwareProvince"` //省份 是 String [省份] 湖南
|
||||
PickwareCity string `json:"pickwareCity"` // 城市 是 String [城市] 长沙
|
||||
PickwareCounty string `json:"pickwareCounty"` // 县区 是 String [县区] 芙蓉区
|
||||
PickwareAddress string `json:"pickwareAddress"` //详细地址 是 String [县区] 塔南路59号2号楼2单元1301室
|
||||
}
|
||||
|
||||
type GetManyPostageReq struct {
|
||||
GoodsInfo string `json:"goodsInfo"` //商品数组 goodsInfo 是 json 需要转成json形式的字符串
|
||||
Address string `json:"address"` // 详细地址 address 是 String
|
||||
County string `json:"county"` // 区 county 是 String
|
||||
Province string `json:"province"` //省份 province 是 String
|
||||
City string `json:"city"` //城市 city 是 String
|
||||
}
|
||||
|
||||
type PreOrderReq struct {
|
||||
LockCode string `json:"lockCode"` //预下单编码 lockCode 是 String
|
||||
ConsigneeContacts string `json:"consigneeContacts"` //收货人姓名 consigneeContacts 是 String
|
||||
ConsigneePhone string `json:"consigneePhone"` //收货人手机号 consigneePhone 是 String
|
||||
Province string `json:"province"` //省份 province 是 String
|
||||
City string `json:"city"` //城市 city 是 String
|
||||
Address string `json:"address"` // 详细地址 address 是 String
|
||||
Area string `json:"area"` //区 area 是 String 区
|
||||
GoodsInfo string `json:"goodsInfo"` //商品数组 goodsInfo 是 json 需要转成json形式的字符串
|
||||
Source string `json:"source"` //订单来源 请求渠道号
|
||||
}
|
||||
|
||||
type GoodsInfo struct {
|
||||
GoodSpecId string `json:"goodSpecId"` //商品ID goodSpecId 是 String 商品ID(c_goods_id)
|
||||
GoodsId string `json:"goodsId"` //商品父 goodsId 是 String 商品父ID(c_father_goods_id)
|
||||
Num string `json:"num"` // 数量
|
||||
}
|
||||
|
||||
type CreateOrderReq struct {
|
||||
LockCode string `json:"lockCode"` //预下单编码 lockCode 是 String
|
||||
OrderNo string `json:"orderNo"` //对接方业务单号 orderNo 是 String
|
||||
NoticeUrl string `json:"noticeUrl"` //合作方通知地址 noticeUrl 否 String 规定值 如支持,订单更新实时通知。此参数可不用传,统一走异步回调
|
||||
}
|
111
weipinshang_api/res.go
Normal file
111
weipinshang_api/res.go
Normal file
@@ -0,0 +1,111 @@
|
||||
package weipinshang_api
|
||||
|
||||
type GetManyPostageRes struct {
|
||||
Code int `json:"code"` // 0为成功,其它为失败
|
||||
Msg string `json:"msg"` // 请求接口消息
|
||||
Data FreightData `json:"data"` // 返回数据 data array
|
||||
}
|
||||
type FreightData struct {
|
||||
Freight string `json:"freight"` // 邮费 freight 是 string 邮费
|
||||
}
|
||||
|
||||
type PreOrderRes struct {
|
||||
Code int `json:"code"` // 0为成功,其它为失败
|
||||
Msg string `json:"msg"` // 请求接口消息
|
||||
Data PreOrderFreightData `json:"data"` // 返回数据 data array
|
||||
}
|
||||
type PreOrderFreightData struct {
|
||||
Freight string `json:"freight"` // 邮费 freight 是 string 邮费
|
||||
FreightDesc string `json:"freight_desc"` // 邮费说明 freight_desc 是 string 邮费说明
|
||||
}
|
||||
|
||||
type CreateOrderRes struct {
|
||||
Code int `json:"code"` // 0为成功,其它为失败
|
||||
Msg string `json:"msg"` // 请求接口消息
|
||||
Data []CreateOrderData `json:"data"` // 返回数据 data array
|
||||
}
|
||||
type CreateOrderData struct {
|
||||
ThirdOrderNo string `json:"thirdOrderNo"` // 第三方订单号 本地订单号
|
||||
OrderNo string `json:"orderNo"` // 主订单号
|
||||
McOrderNo string `json:"mcOrderNo"` //蜜仓子订单号
|
||||
OrderAmount float64 `json:"orderAmount"` // 子订单总金额
|
||||
Sku []SkuData `json:"sku"` // 订单商品信息
|
||||
}
|
||||
|
||||
type SkuData struct {
|
||||
GoodSpecId string `json:"goodSpecId"` //商品ID(c_goods_id)
|
||||
GoodsId string `json:"goodsId"` //商品ID(c_father_goods_id)
|
||||
GoodName string `json:"goodName"` //商品名称
|
||||
Num string `json:"num"` //数量
|
||||
Price string `json:"price"` //单价
|
||||
}
|
||||
|
||||
type GetOrderInfoRes struct {
|
||||
Code int `json:"code"` // 0为成功,其它为失败
|
||||
Msg string `json:"msg"` // 请求接口消息
|
||||
Data []Data `json:"data"` // 返回数据 data array
|
||||
}
|
||||
type Data struct {
|
||||
CThirdUserCode string `json:"c_third_user_code"` // 用户编码
|
||||
COrderNoThird string `json:"c_order_no_third"` // 渠道订单号
|
||||
COrderNoPayservice string `json:"c_order_no_payservice"` //支付订单号
|
||||
CSendStatus string `json:"c_send_status"` // 订单状态 订单所处阶段【’’CHECKED订单被创建’’,’INSTOCK已备货’,’’SENDED已发货’’,’’RECEIVED已收货’’】
|
||||
CIsPay int `json:"c_is_pay"` // 支付状态(0-未支付,1-已支付)
|
||||
CIsClose int `json:"c_is_close"` // 关闭状态 c_is_close 是否关闭【0未关闭,1,已经关闭】
|
||||
CShouldPay float64 `json:"c_should_pay"` // 订单应付金额 单位:元
|
||||
CRealPay float64 `json:"c_real_pay"` // 实际支付金额 c_real_pay 单位:元
|
||||
CMessage string `json:"c_message"` // 订单留言
|
||||
CComment string `json:"c_comment"` // 系统操作备注
|
||||
CDeliveryName string `json:"c_delivery_name"` // 快递公司
|
||||
CDeliveryNo string `json:"c_delivery_no"` // 快递单号
|
||||
CCreateDatetime string `json:"c_create_datetime"` // 订单创建时间
|
||||
CPayDatetime string `json:"c_pay_datetime"` // 订单支付时间
|
||||
CSendDatetime string `json:"c_send_datetime"` // 订单发货时间
|
||||
CReceiveDatetime string `json:"c_receive_datetime"` // 订单确认收货时间
|
||||
CReceiverName string `json:"c_receiver_name"` // 收货人姓名
|
||||
CReceiverMobile string `json:"c_receiver_mobile"` // 收货人联系方式
|
||||
}
|
||||
|
||||
type GetOrderInfoByItemNORes struct {
|
||||
OrderItemNo string `json:"order_item_no"` // 子订单号
|
||||
SendStatus string `json:"send_status"` //发货状态【’CHECKED订单被创建’,’INSTOCK已备货’,’SENDED已发货’,’RECEIVED已收货’】
|
||||
DeliveryName string `json:"delivery_name"` // 快递公司
|
||||
DeliveryNo string `json:"delivery_no"` // 快递单号
|
||||
RefuseStatus string `json:"refuse_status"` //售后状态【CREATED 创建售后单’,’ALLOW同意’,’SUCCESS成功’,’NOTALLOW拒绝’,’MONEY_RETURNED已操作退款’,’FAIL_RETURNED退款失败,线下退款’】
|
||||
RefuseType string `json:"refuse_type"` // 售后类型【’RETURN_MONEY 退款’,’RETURN_GOODS 退货’】
|
||||
}
|
||||
|
||||
type GetOrderInfoByThirdNORes struct {
|
||||
Code int `json:"code"` // 0为成功,其它为失败
|
||||
Msg string `json:"msg"` // 请求接口消息
|
||||
Data []OrderInfoData `json:"data"` // 返回数据 data array
|
||||
}
|
||||
type OrderInfoData struct {
|
||||
OrderItemNo string `json:"order_item_no"` // 子订单号
|
||||
SendStatus string `json:"send_status"` //发货状态【’CHECKED订单被创建’,’INSTOCK已备货’,’SENDED已发货’,’RECEIVED已收货’】
|
||||
DeliveryName string `json:"delivery_name"` // 快递公司
|
||||
DeliveryNo string `json:"delivery_no"` // 快递单号
|
||||
}
|
||||
|
||||
type IsRefundRes struct {
|
||||
Code int `json:"code"` // 0为成功,其它为失败
|
||||
Msg string `json:"msg"` // 请求接口消息
|
||||
ResultType []Param `json:"resultType"` // 售后类型
|
||||
WareReturn []Param `json:"wareReturn"` // 服务类型
|
||||
}
|
||||
|
||||
type Param struct {
|
||||
Code int `json:"code"` // 服务类型码 4 [上门取件(4)、客户发货(40)、客户送货(7)]
|
||||
Name string `json:"name"` // 服务类型名称 上门取件 [上门取件、客户发货、客户送货]
|
||||
}
|
||||
|
||||
type CreateAfsApplyRes struct {
|
||||
Code int `json:"code"` // 0为成功,其它为失败
|
||||
Msg string `json:"msg"` // 请求接口消息
|
||||
Type string `json:"type"` // wait 等待。return_money:已退款
|
||||
}
|
||||
|
||||
type OrderCancelRes struct {
|
||||
Code int `json:"code"` // 0为成功,其它为失败
|
||||
Msg string `json:"msg"` // 请求接口消息
|
||||
}
|
75
weipinshang_api/sign.go
Normal file
75
weipinshang_api/sign.go
Normal file
@@ -0,0 +1,75 @@
|
||||
package weipinshang_api
|
||||
|
||||
import (
|
||||
"encoding/json"
|
||||
"fmt"
|
||||
"sort"
|
||||
"strconv"
|
||||
"strings"
|
||||
)
|
||||
|
||||
func SortedString(data any) string {
|
||||
// 1. 序列化成 JSON
|
||||
dataBytes, err := json.Marshal(data)
|
||||
if err != nil {
|
||||
return ""
|
||||
}
|
||||
|
||||
// 2. 反序列化成 map[string]interface{}
|
||||
var tmp map[string]interface{}
|
||||
if err = json.Unmarshal(dataBytes, &tmp); err != nil {
|
||||
return ""
|
||||
}
|
||||
|
||||
// 3. 提取并排序 keys
|
||||
keys := make([]string, 0, len(tmp))
|
||||
for k := range tmp {
|
||||
keys = append(keys, k)
|
||||
}
|
||||
sort.Strings(keys)
|
||||
|
||||
// 4. 构建键值对字符串
|
||||
var sortedParams []string
|
||||
for _, key := range keys {
|
||||
if key == "hmac" {
|
||||
continue // 跳过 hmac 字段
|
||||
}
|
||||
|
||||
value := tmp[key]
|
||||
strValue, err := valueToString(value)
|
||||
if err != nil {
|
||||
return ""
|
||||
}
|
||||
sortedParams = append(sortedParams, fmt.Sprintf("%s=%s", key, strValue))
|
||||
}
|
||||
return strings.Join(sortedParams, "&")
|
||||
}
|
||||
|
||||
// valueToString 将任意 JSON 值转换为字符串
|
||||
func valueToString(v interface{}) (string, error) {
|
||||
switch i := v.(type) {
|
||||
case string:
|
||||
return i, nil
|
||||
case bool:
|
||||
return strconv.FormatBool(i), nil
|
||||
case float64:
|
||||
// 判断是否是整数(如 2.0 → "2")
|
||||
if i == float64(int64(i)) {
|
||||
return strconv.FormatInt(int64(i), 10), nil
|
||||
}
|
||||
return strconv.FormatFloat(i, 'f', -1, 64), nil
|
||||
case json.Number:
|
||||
return i.String(), nil // 如果使用 json.Number,直接返回其字符串形式
|
||||
case nil:
|
||||
return "", nil
|
||||
case map[string]interface{}, []interface{}:
|
||||
// 如果是嵌套结构,重新序列化成 JSON
|
||||
bytes, err := json.Marshal(i)
|
||||
if err != nil {
|
||||
return "", err
|
||||
}
|
||||
return string(bytes), nil
|
||||
default:
|
||||
return "", fmt.Errorf("unsupported type: %T", i)
|
||||
}
|
||||
}
|
277
weipinshang_api/wei_pin_shang_client.go
Normal file
277
weipinshang_api/wei_pin_shang_client.go
Normal file
@@ -0,0 +1,277 @@
|
||||
package weipinshang_api
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
"crypto/md5"
|
||||
"encoding/hex"
|
||||
"encoding/json"
|
||||
"fmt"
|
||||
"io"
|
||||
"net/http"
|
||||
"strings"
|
||||
)
|
||||
|
||||
type WeiPinShangClient struct {
|
||||
Host string
|
||||
ChannelType string
|
||||
Key string
|
||||
}
|
||||
|
||||
func NewWeiPinShangClient(host, channelType, key string) *WeiPinShangClient {
|
||||
return &WeiPinShangClient{
|
||||
Host: host,
|
||||
ChannelType: channelType,
|
||||
Key: key,
|
||||
}
|
||||
}
|
||||
|
||||
func (w *WeiPinShangClient) GetManyPostage(getManyPostageReq *GetManyPostageReq) (res *GetManyPostageRes, err error) {
|
||||
fmt.Println("getManyPostageReq", getManyPostageReq)
|
||||
paramMap := make(map[string]any)
|
||||
|
||||
paramMap["goodInfo"] = getManyPostageReq.GoodsInfo
|
||||
paramMap["address"] = getManyPostageReq.Address
|
||||
paramMap["province"] = getManyPostageReq.Province
|
||||
paramMap["county"] = getManyPostageReq.County
|
||||
paramMap["city"] = getManyPostageReq.City
|
||||
|
||||
postRes, err := w.WPSPost("mcang/Mcang/getManyPostage", paramMap)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
err = json.Unmarshal(postRes, &res)
|
||||
if err != nil || res == nil {
|
||||
err = fmt.Errorf("转换GetManyPostageRes结构体失败: %s", string(postRes))
|
||||
return
|
||||
}
|
||||
|
||||
return
|
||||
}
|
||||
|
||||
func (w *WeiPinShangClient) PreOrder(preOrderReq *PreOrderReq) (res *PreOrderRes, err error) {
|
||||
fmt.Println("preOrderReq", preOrderReq)
|
||||
paramMap := make(map[string]any)
|
||||
paramMap["lockCode"] = preOrderReq.LockCode
|
||||
paramMap["consigneeContacts"] = preOrderReq.ConsigneeContacts
|
||||
paramMap["consigneePhone"] = preOrderReq.ConsigneePhone
|
||||
|
||||
paramMap["address"] = preOrderReq.Address
|
||||
paramMap["province"] = preOrderReq.Province
|
||||
paramMap["area"] = preOrderReq.Area
|
||||
paramMap["city"] = preOrderReq.City
|
||||
|
||||
paramMap["goodInfo"] = preOrderReq.GoodsInfo
|
||||
paramMap["source"] = preOrderReq.Source
|
||||
postRes, err := w.WPSPost("mcang/Order/preOrder", paramMap)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
err = json.Unmarshal(postRes, &res)
|
||||
if err != nil || res == nil {
|
||||
err = fmt.Errorf("转换PreOrderRes结构体失败: %s", string(postRes))
|
||||
return
|
||||
}
|
||||
|
||||
return
|
||||
}
|
||||
|
||||
func (w *WeiPinShangClient) CreateOrder(createOrderReq *CreateOrderReq) (res *CreateOrderRes, err error) {
|
||||
fmt.Println("createOrderReq", createOrderReq)
|
||||
paramMap := make(map[string]any)
|
||||
paramMap["lockCode"] = createOrderReq.LockCode
|
||||
paramMap["orderNo"] = createOrderReq.OrderNo
|
||||
paramMap["noticeUrl"] = createOrderReq.NoticeUrl
|
||||
postRes, err := w.WPSPost("mcang/Order/createOrder", paramMap)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
err = json.Unmarshal(postRes, &res)
|
||||
if err != nil || res == nil {
|
||||
err = fmt.Errorf("转换CreateOrderRes结构体失败: %s", string(postRes))
|
||||
return
|
||||
}
|
||||
|
||||
return
|
||||
}
|
||||
|
||||
func (w *WeiPinShangClient) GetOrderInfo(orderNo string) (res *GetOrderInfoRes, err error) {
|
||||
fmt.Println("orderNo", orderNo)
|
||||
paramMap := make(map[string]any)
|
||||
paramMap["orderNo"] = orderNo
|
||||
postRes, err := w.WPSPost("mcang/Mcang/getOrderInfo", paramMap)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
err = json.Unmarshal(postRes, &res)
|
||||
if err != nil || res == nil {
|
||||
err = fmt.Errorf("转换GetOrderInfoRes结构体失败: %s", string(postRes))
|
||||
return
|
||||
}
|
||||
|
||||
return
|
||||
}
|
||||
|
||||
func (w *WeiPinShangClient) GetOrderInfoByItemNO(mcOrderNo string) (res *GetOrderInfoByItemNORes, err error) {
|
||||
fmt.Println("mcOrderNo", mcOrderNo)
|
||||
//paramMap := make(map[string]any)
|
||||
//paramMap["mcOrderNo"] = mcOrderNo
|
||||
paramMap := map[string]any{
|
||||
"mcOrderNo": mcOrderNo,
|
||||
}
|
||||
postRes, err := w.WPSPost("mcang/Order/getOrderInfoByItemNO", paramMap)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
err = json.Unmarshal(postRes, &res)
|
||||
if err != nil || res == nil {
|
||||
err = fmt.Errorf("转换GetOrderInfoByItemNORes结构体失败: %s", string(postRes))
|
||||
return
|
||||
}
|
||||
|
||||
return
|
||||
}
|
||||
|
||||
func (w *WeiPinShangClient) GetOrderInfoByThirdNO(orderNo string) (res *GetOrderInfoByThirdNORes, err error) {
|
||||
fmt.Println("orderNo", orderNo)
|
||||
paramMap := make(map[string]any)
|
||||
paramMap["orderNo"] = orderNo
|
||||
postRes, err := w.WPSPost("mcang/Order/getOrderInfoByThirdNO", paramMap)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
err = json.Unmarshal(postRes, &res)
|
||||
if err != nil || res == nil {
|
||||
err = fmt.Errorf("转换GetOrderInfoByThirdNORes结构体失败: %s", string(postRes))
|
||||
return
|
||||
}
|
||||
|
||||
return
|
||||
}
|
||||
|
||||
func (w *WeiPinShangClient) IsRefund(mcOrderNo string) (res *IsRefundRes, err error) {
|
||||
fmt.Println("mcOrderNo", mcOrderNo)
|
||||
paramMap := make(map[string]any)
|
||||
paramMap["mcOrderNo"] = mcOrderNo
|
||||
postRes, err := w.WPSPost("mcang/Refunds/IsRefund", paramMap)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
err = json.Unmarshal(postRes, &res)
|
||||
if err != nil || res == nil {
|
||||
err = fmt.Errorf("转换IsRefundRes结构体失败: %s", string(postRes))
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (w *WeiPinShangClient) CreateAfsApply(createAfsApplyReq *CreateAfsApplyReq) (res *CreateAfsApplyRes, err error) {
|
||||
fmt.Println("createAfsApplyReq", createAfsApplyReq)
|
||||
paramMap := make(map[string]any)
|
||||
|
||||
paramMap["mcOrderNo"] = createAfsApplyReq.McOrderNo
|
||||
|
||||
paramMap["customerExpect"] = createAfsApplyReq.CustomerExpect
|
||||
paramMap["questionDesc"] = createAfsApplyReq.QuestionDesc
|
||||
paramMap["questionPic"] = createAfsApplyReq.QuestionPic
|
||||
paramMap["customerContactName"] = createAfsApplyReq.CustomerContactName
|
||||
paramMap["customerMobilePhone"] = createAfsApplyReq.CustomerMobilePhone
|
||||
paramMap["customerTel"] = createAfsApplyReq.CustomerTel
|
||||
|
||||
paramMap["pickwareProvince"] = createAfsApplyReq.PickwareProvince
|
||||
paramMap["pickwareCity"] = createAfsApplyReq.PickwareCity
|
||||
paramMap["pickwareCounty"] = createAfsApplyReq.PickwareCounty
|
||||
paramMap["pickwareAddress"] = createAfsApplyReq.PickwareAddress
|
||||
|
||||
postRes, err := w.WPSPost("mcang/Refunds/IsRefund", paramMap)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
err = json.Unmarshal(postRes, &res)
|
||||
if err != nil || res == nil {
|
||||
err = fmt.Errorf("转换CreateAfsApplyRes结构体失败: %s", string(postRes))
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (w *WeiPinShangClient) OrderCancel(mcOrderNo string) (res *OrderCancelRes, err error) {
|
||||
fmt.Println("mcOrderNo", mcOrderNo)
|
||||
paramMap := make(map[string]any)
|
||||
paramMap["mcOrderNo"] = mcOrderNo
|
||||
postRes, err := w.WPSPost("mcang/Refunds/IsRefund", paramMap)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
err = json.Unmarshal(postRes, &res)
|
||||
if err != nil || res == nil {
|
||||
err = fmt.Errorf("转换OrderCancelRes结构体失败: %s", string(postRes))
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (w *WeiPinShangClient) Sign(paramMap map[string]any) (res string, err error) {
|
||||
var sumParamString string
|
||||
if len(paramMap) != 0 {
|
||||
sumParamString = SortedString(paramMap) + w.ChannelType + w.Key
|
||||
} else {
|
||||
sumParamString = w.ChannelType + w.Key
|
||||
}
|
||||
md5Sum := md5.Sum([]byte(sumParamString))
|
||||
md5Str := hex.EncodeToString(md5Sum[:])
|
||||
md5Str = strings.ToLower(md5Str)
|
||||
return md5Str, nil
|
||||
}
|
||||
|
||||
func (w *WeiPinShangClient) WPSPost(url string, paramMap map[string]any) (res []byte, err error) {
|
||||
|
||||
bodyByte, _ := json.Marshal(paramMap)
|
||||
|
||||
req, err := http.NewRequest("POST", w.Host+url, bytes.NewBuffer(bodyByte))
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
req.Header.Set("Content-Type", "application/json")
|
||||
req.Header.Set("channelType", w.ChannelType)
|
||||
sign, err := w.Sign(paramMap)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
req.Header.Set("md5", sign)
|
||||
|
||||
// 创建 HTTP 客户端
|
||||
client := &http.Client{}
|
||||
|
||||
// 发送请求
|
||||
resp, err := client.Do(req)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
defer func(Body io.ReadCloser) {
|
||||
_ = Body.Close()
|
||||
}(resp.Body)
|
||||
|
||||
// 读取响应体
|
||||
res, err = io.ReadAll(resp.Body)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
fmt.Printf("res: %s\n", string(res))
|
||||
|
||||
if !json.Valid(res) {
|
||||
return nil, fmt.Errorf("响应不是有效的JSON格式: %s", string(res))
|
||||
}
|
||||
|
||||
return
|
||||
}
|
254
weipinshang_api/wei_pin_shang_client_test.go
Normal file
254
weipinshang_api/wei_pin_shang_client_test.go
Normal file
@@ -0,0 +1,254 @@
|
||||
package weipinshang_api
|
||||
|
||||
import (
|
||||
"log"
|
||||
"testing"
|
||||
)
|
||||
|
||||
func TestWeiPinShangClient_GetManyPostage(t *testing.T) {
|
||||
type fields struct {
|
||||
Host string
|
||||
ChannelType string
|
||||
Key string
|
||||
}
|
||||
//type args struct {
|
||||
// ip string
|
||||
//}
|
||||
tests := []struct {
|
||||
name string
|
||||
fields fields
|
||||
args GetManyPostageReq
|
||||
wantRes *GetManyPostageRes
|
||||
wantErr bool
|
||||
}{
|
||||
{
|
||||
name: "test1",
|
||||
fields: fields{
|
||||
Host: "https://uat.api.weipinshang.net/",
|
||||
ChannelType: "AILEHUI",
|
||||
Key: "f654ea5bde7635c3f46191191e5c4c8e",
|
||||
},
|
||||
args: GetManyPostageReq{
|
||||
GoodsInfo: "[{\"goodsId\":\"WPS592_00019\",\"goodSpecId\":\"WPS592_1105165115160944\",\"num\":1},{\"goodsId\":\"WPS505_00007\",\"goodSpecId\":\"WPS505_1007111249857536\",\"num\":1}]",
|
||||
Province: "广东省",
|
||||
Address: "奥园",
|
||||
City: "广州市",
|
||||
County: "番禺区",
|
||||
},
|
||||
},
|
||||
}
|
||||
for _, test := range tests {
|
||||
t.Run(test.name, func(t *testing.T) {
|
||||
h := &WeiPinShangClient{
|
||||
Host: test.fields.Host,
|
||||
ChannelType: test.fields.ChannelType,
|
||||
Key: test.fields.Key,
|
||||
}
|
||||
|
||||
gotRes, err := h.GetManyPostage(&test.args)
|
||||
|
||||
log.Println(gotRes, err)
|
||||
|
||||
if (err != nil) != test.wantErr {
|
||||
t.Errorf("GetManyPostage() error = %v, wantErr %v", err, test.wantErr)
|
||||
}
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
func TestWeiPinShangClient_PreOrder(t *testing.T) {
|
||||
type fields struct {
|
||||
Host string
|
||||
ChannelType string
|
||||
Key string
|
||||
}
|
||||
//type args struct {
|
||||
// ip string
|
||||
//}
|
||||
tests := []struct {
|
||||
name string
|
||||
fields fields
|
||||
args PreOrderReq
|
||||
wantRes *PreOrderRes
|
||||
wantErr bool
|
||||
}{
|
||||
{
|
||||
name: "test1",
|
||||
fields: fields{
|
||||
Host: "https://uat.api.weipinshang.net/",
|
||||
ChannelType: "AILEHUI",
|
||||
Key: "f654ea5bde7635c3f46191191e5c4c8e",
|
||||
},
|
||||
args: PreOrderReq{
|
||||
GoodsInfo: "[{\"goodsId\":\"WPS9_282520\",\"goodSpecId\":\"WPS9_1221183858889276\",\"num\":1}]",
|
||||
Province: "广东省",
|
||||
Address: "奥园",
|
||||
City: "广州市",
|
||||
Area: "番禺区",
|
||||
ConsigneePhone: "15375390426",
|
||||
ConsigneeContacts: "张三",
|
||||
LockCode: "L1234567890",
|
||||
Source: "AILEHUI",
|
||||
},
|
||||
},
|
||||
}
|
||||
for _, test := range tests {
|
||||
t.Run(test.name, func(t *testing.T) {
|
||||
h := &WeiPinShangClient{
|
||||
Host: test.fields.Host,
|
||||
ChannelType: test.fields.ChannelType,
|
||||
Key: test.fields.Key,
|
||||
}
|
||||
|
||||
gotRes, err := h.PreOrder(&test.args)
|
||||
|
||||
log.Println(gotRes, err)
|
||||
|
||||
if (err != nil) != test.wantErr {
|
||||
t.Errorf("GetManyPostage() error = %v, wantErr %v", err, test.wantErr)
|
||||
}
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
func TestWeiPinShangClient_CreateOrder(t *testing.T) {
|
||||
type fields struct {
|
||||
Host string
|
||||
ChannelType string
|
||||
Key string
|
||||
}
|
||||
//type args struct {
|
||||
// ip string
|
||||
//}
|
||||
tests := []struct {
|
||||
name string
|
||||
fields fields
|
||||
args CreateOrderReq
|
||||
wantRes *CreateOrderRes
|
||||
wantErr bool
|
||||
}{
|
||||
{
|
||||
name: "test1",
|
||||
fields: fields{
|
||||
Host: "https://uat.api.weipinshang.net/",
|
||||
ChannelType: "AILEHUI",
|
||||
Key: "f654ea5bde7635c3f46191191e5c4c8e",
|
||||
},
|
||||
args: CreateOrderReq{
|
||||
LockCode: "L1234567890",
|
||||
OrderNo: "10000000000",
|
||||
},
|
||||
},
|
||||
}
|
||||
for _, test := range tests {
|
||||
t.Run(test.name, func(t *testing.T) {
|
||||
h := &WeiPinShangClient{
|
||||
Host: test.fields.Host,
|
||||
ChannelType: test.fields.ChannelType,
|
||||
Key: test.fields.Key,
|
||||
}
|
||||
|
||||
gotRes, err := h.CreateOrder(&test.args)
|
||||
|
||||
log.Println(gotRes, err)
|
||||
|
||||
if (err != nil) != test.wantErr {
|
||||
t.Errorf("GetManyPostage() error = %v, wantErr %v", err, test.wantErr)
|
||||
}
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
func TestWeiPinShangClient_GetOrderInfoByItemNO(t *testing.T) {
|
||||
type fields struct {
|
||||
Host string
|
||||
ChannelType string
|
||||
Key string
|
||||
}
|
||||
type args struct {
|
||||
mcOrderNo string
|
||||
}
|
||||
tests := []struct {
|
||||
name string
|
||||
fields fields
|
||||
args args
|
||||
wantRes *GetOrderInfoByItemNORes
|
||||
wantErr bool
|
||||
}{
|
||||
{
|
||||
name: "test1",
|
||||
fields: fields{
|
||||
Host: "https://uat.api.weipinshang.net/",
|
||||
ChannelType: "AILEHUI",
|
||||
Key: "f654ea5bde7635c3f46191191e5c4c8e",
|
||||
},
|
||||
args: args{
|
||||
mcOrderNo: "mc20250527174640537475",
|
||||
},
|
||||
},
|
||||
}
|
||||
for _, test := range tests {
|
||||
t.Run(test.name, func(t *testing.T) {
|
||||
h := &WeiPinShangClient{
|
||||
Host: test.fields.Host,
|
||||
ChannelType: test.fields.ChannelType,
|
||||
Key: test.fields.Key,
|
||||
}
|
||||
|
||||
gotRes, err := h.GetOrderInfoByItemNO(test.args.mcOrderNo)
|
||||
|
||||
log.Println(gotRes, err)
|
||||
|
||||
if (err != nil) != test.wantErr {
|
||||
t.Errorf("GetManyPostage() error = %v, wantErr %v", err, test.wantErr)
|
||||
}
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
func TestWeiPinShangClient_GetOrderInfoByThirdNO(t *testing.T) {
|
||||
type fields struct {
|
||||
Host string
|
||||
ChannelType string
|
||||
Key string
|
||||
}
|
||||
type args struct {
|
||||
orderNo string
|
||||
}
|
||||
tests := []struct {
|
||||
name string
|
||||
fields fields
|
||||
args args
|
||||
wantRes *GetOrderInfoByThirdNORes
|
||||
wantErr bool
|
||||
}{
|
||||
{
|
||||
name: "test1",
|
||||
fields: fields{
|
||||
Host: "https://uat.api.weipinshang.net/",
|
||||
ChannelType: "AILEHUI",
|
||||
Key: "f654ea5bde7635c3f46191191e5c4c8e",
|
||||
},
|
||||
args: args{
|
||||
orderNo: "10000000000",
|
||||
},
|
||||
},
|
||||
}
|
||||
for _, test := range tests {
|
||||
t.Run(test.name, func(t *testing.T) {
|
||||
h := &WeiPinShangClient{
|
||||
Host: test.fields.Host,
|
||||
ChannelType: test.fields.ChannelType,
|
||||
Key: test.fields.Key,
|
||||
}
|
||||
|
||||
gotRes, err := h.GetOrderInfoByThirdNO(test.args.orderNo)
|
||||
|
||||
log.Println(gotRes, err)
|
||||
|
||||
if (err != nil) != test.wantErr {
|
||||
t.Errorf("GetManyPostage() error = %v, wantErr %v", err, test.wantErr)
|
||||
}
|
||||
})
|
||||
}
|
||||
}
|
Reference in New Issue
Block a user