client_merchant_order.go

// @description wechat 是腾讯微信公众平台 api 的 golang 语言封装
// @link        https://github.com/chanxuehong/wechat for the canonical source repository
// @license     https://github.com/chanxuehong/wechat/blob/master/LICENSE
// @authors     chanxuehong(chanxuehong@gmail.com)

package client

import (
	"github.com/chanxuehong/wechat/merchant/order"
)

// 根据订单id获取订单详情
func (c *Client) MerchantOrderGetById(orderId string) (_order *order.Order, err error) {
	var request = struct {
		OrderId string `json:"order_id"`
	}{
		OrderId: orderId,
	}

	var result struct {
		Error
		Order order.Order `json:"order"`
	}

	hasRetry := false
RETRY:
	token, err := c.Token()
	if err != nil {
		return
	}
	_url := merchantOrderGetByIdURL(token)
	if err = c.postJSON(_url, request, &result); err != nil {
		return
	}

	switch result.ErrCode {
	case errCodeOK:
		_order = &result.Order
		return

	case errCodeTimeout:
		if !hasRetry {
			hasRetry = true
			timeoutRetryWait()
			goto RETRY
		}
		fallthrough

	default:
		err = &result.Error
		return
	}
}

// 根据订单状态/创建时间获取订单详情
//  @status:    订单状态, 不带该字段(==0) -全部状态, 2-待发货, 3-已发货, 5-已完成, 8-维权中
//  @beginTime: 订单创建时间起始时间, 不带该字段(==0) 则不按照时间做筛选
//  @endTime:   订单创建时间终止时间, 不带该字段(==0) 则不按照时间做筛选
func (c *Client) MerchantOrderGetByFilter(status int, beginTime, endTime int64) (orders []order.Order, err error) {
	var request = struct {
		Status    int   `json:"status,omitempty"`
		BeginTime int64 `json:"begintime,omitempty"`
		EndTime   int64 `json:"endtime,omitempty"`
	}{
		Status:    status,
		BeginTime: beginTime,
		EndTime:   endTime,
	}

	var result struct {
		Error
		OrderList []order.Order `json:"order_list"`
	}
	result.OrderList = make([]order.Order, 0, 64)

	hasRetry := false
RETRY:
	token, err := c.Token()
	if err != nil {
		return
	}
	_url := merchantOrderGetByFilterURL(token)
	if err = c.postJSON(_url, &request, &result); err != nil {
		return
	}

	switch result.ErrCode {
	case errCodeOK:
		orders = result.OrderList
		return

	case errCodeTimeout:
		if !hasRetry {
			hasRetry = true
			timeoutRetryWait()
			goto RETRY
		}
		fallthrough

	default:
		err = &result.Error
		return
	}
}

// 设置订单发货信息.
//  @orderId:         订单ID;
//  @deliveryCompany: 物流公司ID(参考《物流公司ID》)
//  @deliveryTrackNo: 运单ID
func (c *Client) MerchantOrderSetDelivery(orderId, deliveryCompany, deliveryTrackNo string) (err error) {
	var request = struct {
		OrderId         string `json:"order_id"`
		DeliveryCompany string `json:"delivery_company"`
		DeliveryTrackNo string `json:"delivery_track_no"`
	}{
		OrderId:         orderId,
		DeliveryCompany: deliveryCompany,
		DeliveryTrackNo: deliveryTrackNo,
	}

	var result Error

	hasRetry := false
RETRY:
	token, err := c.Token()
	if err != nil {
		return
	}
	_url := merchantOrderSetDeliveryURL(token)
	if err = c.postJSON(_url, &request, &result); err != nil {
		return
	}

	switch result.ErrCode {
	case errCodeOK:
		return

	case errCodeTimeout:
		if !hasRetry {
			hasRetry = true
			timeoutRetryWait()
			goto RETRY
		}
		fallthrough

	default:
		err = &result
		return
	}
}

// 关闭订单
func (c *Client) MerchantOrderClose(orderId string) (err error) {
	var request = struct {
		OrderId string `json:"order_id"`
	}{
		OrderId: orderId,
	}

	var result Error

	hasRetry := false
RETRY:
	token, err := c.Token()
	if err != nil {
		return
	}
	_url := merchantOrderCloseURL(token)
	if err = c.postJSON(_url, request, &result); err != nil {
		return
	}

	switch result.ErrCode {
	case errCodeOK:
		return

	case errCodeTimeout:
		if !hasRetry {
			hasRetry = true
			timeoutRetryWait()
			goto RETRY
		}
		fallthrough

	default:
		err = &result
		return
	}
}