mirror of
https://github.com/silenceper/wechat.git
synced 2026-02-04 12:52:27 +08:00
f0f35e2f77
* feat(media): add getTempFile api add getTempFile api * feat(miniprogram): add intracity delivery service APIs Add WeChat intracity (same-city) delivery service APIs including: - Store management: Apply, Create, Query, Update store - Payment: StoreCharge, StoreRefund, QueryFlow, BalanceQuery - Order management: PreAddOrder, AddOrder, QueryOrder, CancelOrder Ref: https://developers.weixin.qq.com/miniprogram/dev/platform-capabilities/industry/express/business/intracity_service.html --------- Co-authored-by: lumiaqian <cjj1@truesightai.com>
619 lines
26 KiB
Go
619 lines
26 KiB
Go
package express
|
||
|
||
import (
|
||
"context"
|
||
"fmt"
|
||
|
||
"github.com/silenceper/wechat/v2/util"
|
||
)
|
||
|
||
// 同城配送 API URL
|
||
// https://developers.weixin.qq.com/miniprogram/dev/platform-capabilities/industry/express/business/intracity_service.html
|
||
const (
|
||
// 开通门店权限
|
||
intracityApplyURL = "https://api.weixin.qq.com/cgi-bin/express/intracity/apply?access_token=%s"
|
||
// 创建门店
|
||
intracityCreateStoreURL = "https://api.weixin.qq.com/cgi-bin/express/intracity/createstore?access_token=%s"
|
||
// 查询门店
|
||
intracityQueryStoreURL = "https://api.weixin.qq.com/cgi-bin/express/intracity/querystore?access_token=%s"
|
||
// 更新门店
|
||
intracityUpdateStoreURL = "https://api.weixin.qq.com/cgi-bin/express/intracity/updatestore?access_token=%s"
|
||
// 门店运费充值
|
||
intracityStoreChargeURL = "https://api.weixin.qq.com/cgi-bin/express/intracity/storecharge?access_token=%s"
|
||
// 门店运费退款
|
||
intracityStoreRefundURL = "https://api.weixin.qq.com/cgi-bin/express/intracity/storerefund?access_token=%s"
|
||
// 门店运费流水查询
|
||
intracityQueryFlowURL = "https://api.weixin.qq.com/cgi-bin/express/intracity/queryflow?access_token=%s"
|
||
// 门店余额查询
|
||
intracityBalanceQueryURL = "https://api.weixin.qq.com/cgi-bin/express/intracity/balancequery?access_token=%s"
|
||
// 预下配送单（查询运费）
|
||
intracityPreAddOrderURL = "https://api.weixin.qq.com/cgi-bin/express/intracity/preaddorder?access_token=%s"
|
||
// 创建配送单
|
||
intracityAddOrderURL = "https://api.weixin.qq.com/cgi-bin/express/intracity/addorder?access_token=%s"
|
||
// 查询配送单
|
||
intracityQueryOrderURL = "https://api.weixin.qq.com/cgi-bin/express/intracity/queryorder?access_token=%s"
|
||
// 取消配送单
|
||
intracityCancelOrderURL = "https://api.weixin.qq.com/cgi-bin/express/intracity/cancelorder?access_token=%s"
|
||
// 模拟配送回调（仅用于测试）
|
||
intracityMockNotifyURL = "https://api.weixin.qq.com/cgi-bin/express/intracity/mocknotify?access_token=%s"
|
||
)
|
||
|
||
// PayMode 充值/扣费主体
|
||
type PayMode string
|
||
|
||
const (
|
||
// PayModeStore 门店
|
||
PayModeStore PayMode = "PAY_MODE_STORE"
|
||
// PayModeApp 小程序
|
||
PayModeApp PayMode = "PAY_MODE_APP"
|
||
// PayModeComponent 服务商
|
||
PayModeComponent PayMode = "PAY_MODE_COMPONENT"
|
||
)
|
||
|
||
// OrderPattern 运力偏好
|
||
type OrderPattern uint32
|
||
|
||
const (
|
||
// OrderPatternPriceFirst 价格优先
|
||
OrderPatternPriceFirst OrderPattern = 1
|
||
// OrderPatternTransFirst 运力优先
|
||
OrderPatternTransFirst OrderPattern = 2
|
||
)
|
||
|
||
// FlowType 流水类型
|
||
type FlowType uint32
|
||
|
||
const (
|
||
// FlowTypeCharge 充值流水
|
||
FlowTypeCharge FlowType = 1
|
||
// FlowTypeConsume 消费流水
|
||
FlowTypeConsume FlowType = 2
|
||
// FlowTypeRefund 退款流水
|
||
FlowTypeRefund FlowType = 3
|
||
)
|
||
|
||
// IntracityDeliveryStatus 配送单状态
|
||
type IntracityDeliveryStatus int32
|
||
|
||
const (
|
||
// IntracityDeliveryStatusReady 配送单待接单
|
||
IntracityDeliveryStatusReady IntracityDeliveryStatus = 100
|
||
// IntracityDeliveryStatusPickedUp 配送单待取货
|
||
IntracityDeliveryStatusPickedUp IntracityDeliveryStatus = 101
|
||
// IntracityDeliveryStatusOngoing 配送单配送中
|
||
IntracityDeliveryStatusOngoing IntracityDeliveryStatus = 102
|
||
// IntracityDeliveryStatusFinished 配送单已送达
|
||
IntracityDeliveryStatusFinished IntracityDeliveryStatus = 200
|
||
// IntracityDeliveryStatusCancelled 配送单已取消
|
||
IntracityDeliveryStatusCancelled IntracityDeliveryStatus = 300
|
||
// IntracityDeliveryStatusAbnormal 配送单异常
|
||
IntracityDeliveryStatusAbnormal IntracityDeliveryStatus = 400
|
||
)
|
||
|
||
// IntracityAddressInfo 门店地址信息
|
||
type IntracityAddressInfo struct {
|
||
Province string `json:"province"` // 省/自治区/直辖市
|
||
City string `json:"city"` // 地级市
|
||
Area string `json:"area"` // 县/县级市/区
|
||
Street string `json:"street"` // 街道
|
||
House string `json:"house"` // 具体门牌号或详细地址
|
||
Lat float64 `json:"lat"` // 门店所在地纬度
|
||
Lng float64 `json:"lng"` // 门店所在地经度
|
||
Phone string `json:"phone"` // 门店联系电话
|
||
Name string `json:"name,omitempty"` // 联系人姓名（收货地址时使用）
|
||
}
|
||
|
||
// IntracityStoreInfo 门店信息
|
||
type IntracityStoreInfo struct {
|
||
WxStoreID string `json:"wx_store_id"` // 微信门店编号
|
||
OutStoreID string `json:"out_store_id"` // 自定义门店编号
|
||
CityID string `json:"city_id"` // 门店所在城市ID
|
||
StoreName string `json:"store_name"` // 门店名称
|
||
OrderPattern OrderPattern `json:"order_pattern"` // 运力偏好
|
||
ServiceTransPrefer string `json:"service_trans_prefer"` // 优先使用的运力ID
|
||
AddressInfo IntracityAddressInfo `json:"address_info"` // 门店地址信息
|
||
}
|
||
|
||
// ============ 门店管理接口 ============
|
||
|
||
// IntracityApply 开通门店权限
|
||
// https://developers.weixin.qq.com/miniprogram/dev/platform-capabilities/industry/express/business/intracity_service.html
|
||
func (express *Express) IntracityApply(ctx context.Context) error {
|
||
accessToken, err := express.GetAccessToken()
|
||
if err != nil {
|
||
return err
|
||
}
|
||
|
||
uri := fmt.Sprintf(intracityApplyURL, accessToken)
|
||
response, err := util.PostJSONContext(ctx, uri, map[string]interface{}{})
|
||
if err != nil {
|
||
return err
|
||
}
|
||
|
||
return util.DecodeWithCommonError(response, "IntracityApply")
|
||
}
|
||
|
||
// CreateStoreRequest 创建门店请求参数
|
||
type CreateStoreRequest struct {
|
||
OutStoreID string `json:"out_store_id"` // 自定义门店编号
|
||
StoreName string `json:"store_name"` // 门店名称
|
||
OrderPattern OrderPattern `json:"order_pattern,omitempty"` // 运力偏好：1-价格优先，2-运力优先
|
||
ServiceTransPrefer string `json:"service_trans_prefer,omitempty"` // 优先使用的运力ID，order_pattern=2时必填
|
||
AddressInfo IntracityAddressInfo `json:"address_info"` // 门店地址信息
|
||
}
|
||
|
||
// CreateStoreResponse 创建门店返回参数
|
||
type CreateStoreResponse struct {
|
||
util.CommonError
|
||
WxStoreID string `json:"wx_store_id"` // 微信门店编号
|
||
AppID string `json:"appid"` // 小程序appid
|
||
OutStoreID string `json:"out_store_id"` // 自定义门店ID
|
||
}
|
||
|
||
// IntracityCreateStore 创建门店
|
||
func (express *Express) IntracityCreateStore(ctx context.Context, req *CreateStoreRequest) (res CreateStoreResponse, err error) {
|
||
accessToken, err := express.GetAccessToken()
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
uri := fmt.Sprintf(intracityCreateStoreURL, accessToken)
|
||
response, err := util.PostJSONContext(ctx, uri, req)
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
err = util.DecodeWithError(response, &res, "IntracityCreateStore")
|
||
return
|
||
}
|
||
|
||
// QueryStoreRequest 查询门店请求参数
|
||
type QueryStoreRequest struct {
|
||
WxStoreID string `json:"wx_store_id,omitempty"` // 微信门店编号
|
||
OutStoreID string `json:"out_store_id,omitempty"` // 自定义门店编号
|
||
}
|
||
|
||
// QueryStoreResponse 查询门店返回参数
|
||
type QueryStoreResponse struct {
|
||
util.CommonError
|
||
Total uint32 `json:"total"` // 符合条件的门店总数
|
||
AppID string `json:"appid"` // 小程序appid
|
||
StoreList []IntracityStoreInfo `json:"store_list"` // 门店信息列表
|
||
}
|
||
|
||
// IntracityQueryStore 查询门店
|
||
func (express *Express) IntracityQueryStore(ctx context.Context, req *QueryStoreRequest) (res QueryStoreResponse, err error) {
|
||
accessToken, err := express.GetAccessToken()
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
uri := fmt.Sprintf(intracityQueryStoreURL, accessToken)
|
||
response, err := util.PostJSONContext(ctx, uri, req)
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
err = util.DecodeWithError(response, &res, "IntracityQueryStore")
|
||
return
|
||
}
|
||
|
||
// UpdateStoreKeyInfo 更新门店的key信息
|
||
type UpdateStoreKeyInfo struct {
|
||
WxStoreID string `json:"wx_store_id,omitempty"` // 微信门店编号
|
||
OutStoreID string `json:"out_store_id,omitempty"` // 自定义门店编号，二选一
|
||
}
|
||
|
||
// UpdateStoreContent 更新门店的内容
|
||
type UpdateStoreContent struct {
|
||
StoreName string `json:"store_name,omitempty"` // 门店名称
|
||
OrderPattern OrderPattern `json:"order_pattern,omitempty"` // 运力偏好
|
||
ServiceTransPrefer string `json:"service_trans_prefer,omitempty"` // 优先使用的运力ID
|
||
AddressInfo *IntracityAddressInfo `json:"address_info,omitempty"` // 门店地址信息
|
||
}
|
||
|
||
// UpdateStoreRequest 更新门店请求参数
|
||
type UpdateStoreRequest struct {
|
||
Keys UpdateStoreKeyInfo `json:"keys"` // 门店编号
|
||
Content UpdateStoreContent `json:"content"` // 更新内容
|
||
}
|
||
|
||
// IntracityUpdateStore 更新门店
|
||
func (express *Express) IntracityUpdateStore(ctx context.Context, req *UpdateStoreRequest) error {
|
||
accessToken, err := express.GetAccessToken()
|
||
if err != nil {
|
||
return err
|
||
}
|
||
|
||
uri := fmt.Sprintf(intracityUpdateStoreURL, accessToken)
|
||
response, err := util.PostJSONContext(ctx, uri, req)
|
||
if err != nil {
|
||
return err
|
||
}
|
||
|
||
return util.DecodeWithCommonError(response, "IntracityUpdateStore")
|
||
}
|
||
|
||
// ============ 充值退款接口 ============
|
||
|
||
// StoreChargeRequest 门店运费充值请求参数
|
||
type StoreChargeRequest struct {
|
||
WxStoreID string `json:"wx_store_id,omitempty"` // 微信门店编号，pay_mode=PAY_MODE_STORE时必传
|
||
ServiceTransID string `json:"service_trans_id"` // 运力ID
|
||
Amount uint32 `json:"amount"` // 充值金额，单位：分，50元起充
|
||
PayMode PayMode `json:"pay_mode,omitempty"` // 充值主体
|
||
}
|
||
|
||
// StoreChargeResponse 门店运费充值返回参数
|
||
type StoreChargeResponse struct {
|
||
util.CommonError
|
||
PayURL string `json:"payurl"` // 充值页面地址
|
||
AppID string `json:"appid"` // 小程序appid
|
||
WxStoreID string `json:"wx_store_id"` // 微信门店编号
|
||
}
|
||
|
||
// IntracityStoreCharge 门店运费充值
|
||
func (express *Express) IntracityStoreCharge(ctx context.Context, req *StoreChargeRequest) (res StoreChargeResponse, err error) {
|
||
accessToken, err := express.GetAccessToken()
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
uri := fmt.Sprintf(intracityStoreChargeURL, accessToken)
|
||
response, err := util.PostJSONContext(ctx, uri, req)
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
err = util.DecodeWithError(response, &res, "IntracityStoreCharge")
|
||
return
|
||
}
|
||
|
||
// StoreRefundRequest 门店运费退款请求参数
|
||
type StoreRefundRequest struct {
|
||
WxStoreID string `json:"wx_store_id,omitempty"` // 微信门店编号
|
||
PayMode PayMode `json:"pay_mode,omitempty"` // 充值/扣费主体
|
||
ServiceTransID string `json:"service_trans_id"` // 运力ID
|
||
}
|
||
|
||
// StoreRefundResponse 门店运费退款返回参数
|
||
type StoreRefundResponse struct {
|
||
util.CommonError
|
||
AppID string `json:"appid"` // 小程序appid
|
||
WxStoreID string `json:"wx_store_id"` // 微信门店编号
|
||
RefundAmount uint32 `json:"refund_amount"` // 退款金额，单位：分
|
||
}
|
||
|
||
// IntracityStoreRefund 门店运费退款
|
||
func (express *Express) IntracityStoreRefund(ctx context.Context, req *StoreRefundRequest) (res StoreRefundResponse, err error) {
|
||
accessToken, err := express.GetAccessToken()
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
uri := fmt.Sprintf(intracityStoreRefundURL, accessToken)
|
||
response, err := util.PostJSONContext(ctx, uri, req)
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
err = util.DecodeWithError(response, &res, "IntracityStoreRefund")
|
||
return
|
||
}
|
||
|
||
// QueryFlowRequest 门店运费流水查询请求参数
|
||
type QueryFlowRequest struct {
|
||
WxStoreID string `json:"wx_store_id"` // 微信门店编号
|
||
FlowType FlowType `json:"flow_type"` // 流水类型：1-充值，2-消费，3-退款
|
||
ServiceTransID string `json:"service_trans_id,omitempty"` // 运力ID
|
||
BeginTime uint32 `json:"begin_time,omitempty"` // 开始时间戳
|
||
EndTime uint32 `json:"end_time,omitempty"` // 结束时间戳
|
||
PayMode PayMode `json:"pay_mode"` // 扣费主体
|
||
}
|
||
|
||
// FlowRecordInfo 流水记录信息
|
||
type FlowRecordInfo struct {
|
||
FlowType FlowType `json:"flow_type"` // 流水类型
|
||
AppID string `json:"appid"` // appid
|
||
WxStoreID string `json:"wx_store_id"` // 微信门店ID
|
||
PayOrderID uint64 `json:"pay_order_id,omitempty"` // 充值订单号
|
||
WxOrderID string `json:"wx_order_id,omitempty"` // 订单ID（消费流水）
|
||
ServiceTransID string `json:"service_trans_id"` // 运力ID
|
||
OpenID string `json:"openid,omitempty"` // 用户openid（消费流水）
|
||
DeliveryStatus int32 `json:"delivery_status,omitempty"` // 运单状态（消费流水）
|
||
PayAmount int32 `json:"pay_amount"` // 支付金额，单位：分
|
||
PayTime uint32 `json:"pay_time,omitempty"` // 支付时间
|
||
PayStatus string `json:"pay_status,omitempty"` // 支付状态
|
||
RefundStatus string `json:"refund_status,omitempty"` // 退款状态
|
||
RefundAmount int32 `json:"refund_amount,omitempty"` // 退款金额
|
||
RefundTime uint32 `json:"refund_time,omitempty"` // 退款时间
|
||
DeductAmount int32 `json:"deduct_amount,omitempty"` // 扣除违约金
|
||
CreateTime uint32 `json:"create_time"` // 创建时间
|
||
ConsumeDeadline uint32 `json:"consume_deadline,omitempty"` // 有效截止日期
|
||
BillID string `json:"bill_id,omitempty"` // 运单ID
|
||
DeliveryFinishedTime uint32 `json:"delivery_finished_time,omitempty"` // 运单完成配送的时间
|
||
}
|
||
|
||
// QueryFlowResponse 门店运费流水查询返回参数
|
||
type QueryFlowResponse struct {
|
||
util.CommonError
|
||
Total uint32 `json:"total"` // 总数
|
||
FlowList []FlowRecordInfo `json:"flow_list"` // 流水数组
|
||
TotalPayAmt int `json:"total_pay_amt"` // 总支付金额
|
||
TotalRefundAmt int `json:"total_refund_amt"` // 总退款金额
|
||
TotalDeductAmt int `json:"total_deduct_amt"` // 总违约金（消费流水返回）
|
||
}
|
||
|
||
// IntracityQueryFlow 门店运费流水查询
|
||
func (express *Express) IntracityQueryFlow(ctx context.Context, req *QueryFlowRequest) (res QueryFlowResponse, err error) {
|
||
accessToken, err := express.GetAccessToken()
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
uri := fmt.Sprintf(intracityQueryFlowURL, accessToken)
|
||
response, err := util.PostJSONContext(ctx, uri, req)
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
err = util.DecodeWithError(response, &res, "IntracityQueryFlow")
|
||
return
|
||
}
|
||
|
||
// BalanceQueryRequest 门店余额查询请求参数
|
||
type BalanceQueryRequest struct {
|
||
WxStoreID string `json:"wx_store_id,omitempty"` // 微信门店编号
|
||
ServiceTransID string `json:"service_trans_id,omitempty"` // 运力ID
|
||
PayMode PayMode `json:"pay_mode,omitempty"` // 充值/扣费主体
|
||
}
|
||
|
||
// BalanceInfo 余额信息
|
||
type BalanceInfo struct {
|
||
ServiceTransID string `json:"service_trans_id"` // 运力ID
|
||
Balance int32 `json:"balance"` // 余额，单位：分
|
||
}
|
||
|
||
// BalanceQueryResponse 门店余额查询返回参数
|
||
type BalanceQueryResponse struct {
|
||
util.CommonError
|
||
AppID string `json:"appid"` // 小程序appid
|
||
WxStoreID string `json:"wx_store_id"` // 微信门店编号
|
||
BalanceList []BalanceInfo `json:"balance_list"` // 余额列表
|
||
}
|
||
|
||
// IntracityBalanceQuery 门店余额查询
|
||
func (express *Express) IntracityBalanceQuery(ctx context.Context, req *BalanceQueryRequest) (res BalanceQueryResponse, err error) {
|
||
accessToken, err := express.GetAccessToken()
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
uri := fmt.Sprintf(intracityBalanceQueryURL, accessToken)
|
||
response, err := util.PostJSONContext(ctx, uri, req)
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
err = util.DecodeWithError(response, &res, "IntracityBalanceQuery")
|
||
return
|
||
}
|
||
|
||
// ============ 配送订单接口 ============
|
||
|
||
// CargoInfo 货物信息
|
||
type CargoInfo struct {
|
||
Name string `json:"name"` // 货物名称
|
||
Num uint32 `json:"num,omitempty"` // 货物数量
|
||
Price uint32 `json:"price,omitempty"` // 货物价格，单位：分
|
||
Weight uint32 `json:"weight,omitempty"` // 货物重量，单位：克
|
||
}
|
||
|
||
// PreAddOrderRequest 预下配送单请求参数
|
||
type PreAddOrderRequest struct {
|
||
WxStoreID string `json:"wx_store_id,omitempty"` // 微信门店编号，二选一
|
||
OutStoreID string `json:"out_store_id,omitempty"` // 自定义门店编号，二选一
|
||
UserOpenID string `json:"user_openid"` // 用户openid
|
||
UserPhone string `json:"user_phone,omitempty"` // 用户联系电话
|
||
UserName string `json:"user_name,omitempty"` // 用户姓名
|
||
UserLat float64 `json:"user_lat"` // 用户地址纬度
|
||
UserLng float64 `json:"user_lng"` // 用户地址经度
|
||
UserAddress string `json:"user_address"` // 用户详细地址
|
||
ServiceTransID string `json:"service_trans_id,omitempty"` // 运力ID，不传则查询所有运力
|
||
PayMode PayMode `json:"pay_mode,omitempty"` // 充值/扣费主体
|
||
CargoInfo *CargoInfo `json:"cargo_info,omitempty"` // 货物信息
|
||
}
|
||
|
||
// TransInfo 运力信息
|
||
type TransInfo struct {
|
||
ServiceTransID string `json:"service_trans_id"` // 运力ID
|
||
ServiceName string `json:"service_name"` // 运力名称
|
||
Price uint32 `json:"price"` // 配送费用，单位：分
|
||
Distance uint32 `json:"distance"` // 配送距离，单位：米
|
||
Errcode int `json:"errcode"` // 错误码，0表示成功
|
||
Errmsg string `json:"errmsg"` // 错误信息
|
||
}
|
||
|
||
// PreAddOrderResponse 预下配送单返回参数
|
||
type PreAddOrderResponse struct {
|
||
util.CommonError
|
||
WxStoreID string `json:"wx_store_id"` // 微信门店编号
|
||
AppID string `json:"appid"` // 小程序appid
|
||
TransList []TransInfo `json:"trans_list"` // 运力列表
|
||
}
|
||
|
||
// IntracityPreAddOrder 预下配送单（查询运费）
|
||
func (express *Express) IntracityPreAddOrder(ctx context.Context, req *PreAddOrderRequest) (res PreAddOrderResponse, err error) {
|
||
accessToken, err := express.GetAccessToken()
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
uri := fmt.Sprintf(intracityPreAddOrderURL, accessToken)
|
||
response, err := util.PostJSONContext(ctx, uri, req)
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
err = util.DecodeWithError(response, &res, "IntracityPreAddOrder")
|
||
return
|
||
}
|
||
|
||
// AddOrderRequest 创建配送单请求参数
|
||
type AddOrderRequest struct {
|
||
WxStoreID string `json:"wx_store_id,omitempty"` // 微信门店编号，二选一
|
||
OutStoreID string `json:"out_store_id,omitempty"` // 自定义门店编号，二选一
|
||
OutOrderID string `json:"out_order_id"` // 自定义订单号，需唯一
|
||
ServiceTransID string `json:"service_trans_id,omitempty"` // 运力ID
|
||
UserOpenID string `json:"user_openid"` // 用户openid
|
||
UserPhone string `json:"user_phone"` // 用户联系电话
|
||
UserName string `json:"user_name"` // 用户姓名
|
||
UserLat float64 `json:"user_lat"` // 用户地址纬度
|
||
UserLng float64 `json:"user_lng"` // 用户地址经度
|
||
UserAddress string `json:"user_address"` // 用户详细地址
|
||
PayMode PayMode `json:"pay_mode,omitempty"` // 充值/扣费主体
|
||
CargoInfo *CargoInfo `json:"cargo_info,omitempty"` // 货物信息
|
||
OrderDetailPath string `json:"order_detail_path,omitempty"` // 订单详情页路径
|
||
CallbackURL string `json:"callback_url,omitempty"` // 配送状态回调URL
|
||
UseInsurance uint32 `json:"use_insurance,omitempty"` // 是否使用保价：0-不使用，1-使用
|
||
InsuranceValue uint32 `json:"insurance_value,omitempty"` // 保价金额，单位：分
|
||
ExpectTime uint32 `json:"expect_time,omitempty"` // 期望送达时间戳
|
||
Remark string `json:"remark,omitempty"` // 备注
|
||
}
|
||
|
||
// AddOrderResponse 创建配送单返回参数
|
||
type AddOrderResponse struct {
|
||
util.CommonError
|
||
WxOrderID string `json:"wx_order_id"` // 微信订单号
|
||
AppID string `json:"appid"` // 小程序appid
|
||
WxStoreID string `json:"wx_store_id"` // 微信门店编号
|
||
OutOrderID string `json:"out_order_id"` // 自定义订单号
|
||
ServiceTransID string `json:"service_trans_id"` // 运力ID
|
||
BillID string `json:"bill_id"` // 运力订单号
|
||
Price uint32 `json:"price"` // 配送费用，单位：分
|
||
Distance uint32 `json:"distance"` // 配送距离，单位：米
|
||
}
|
||
|
||
// IntracityAddOrder 创建配送单
|
||
func (express *Express) IntracityAddOrder(ctx context.Context, req *AddOrderRequest) (res AddOrderResponse, err error) {
|
||
accessToken, err := express.GetAccessToken()
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
uri := fmt.Sprintf(intracityAddOrderURL, accessToken)
|
||
response, err := util.PostJSONContext(ctx, uri, req)
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
err = util.DecodeWithError(response, &res, "IntracityAddOrder")
|
||
return
|
||
}
|
||
|
||
// QueryOrderRequest 查询配送单请求参数
|
||
type QueryOrderRequest struct {
|
||
WxOrderID string `json:"wx_order_id,omitempty"` // 微信订单号，二选一
|
||
OutOrderID string `json:"out_order_id,omitempty"` // 自定义订单号，二选一
|
||
WxStoreID string `json:"wx_store_id,omitempty"` // 微信门店编号
|
||
OutStoreID string `json:"out_store_id,omitempty"` // 自定义门店编号
|
||
}
|
||
|
||
// RiderInfo 骑手信息
|
||
type RiderInfo struct {
|
||
Name string `json:"name"` // 骑手姓名
|
||
Phone string `json:"phone"` // 骑手电话
|
||
RiderCode string `json:"rider_code"` // 骑手编号
|
||
RiderImgURL string `json:"rider_img_url"` // 骑手头像URL
|
||
}
|
||
|
||
// QueryOrderResponse 查询配送单返回参数
|
||
type QueryOrderResponse struct {
|
||
util.CommonError
|
||
WxOrderID string `json:"wx_order_id"` // 微信订单号
|
||
AppID string `json:"appid"` // 小程序appid
|
||
WxStoreID string `json:"wx_store_id"` // 微信门店编号
|
||
OutOrderID string `json:"out_order_id"` // 自定义订单号
|
||
ServiceTransID string `json:"service_trans_id"` // 运力ID
|
||
BillID string `json:"bill_id"` // 运力订单号
|
||
DeliveryStatus IntracityDeliveryStatus `json:"delivery_status"` // 配送状态
|
||
Price uint32 `json:"price"` // 配送费用，单位：分
|
||
Distance uint32 `json:"distance"` // 配送距离，单位：米
|
||
CreateTime uint32 `json:"create_time"` // 订单创建时间
|
||
RiderInfo *RiderInfo `json:"rider_info"` // 骑手信息
|
||
FinishTime uint32 `json:"finish_time"` // 订单完成时间
|
||
}
|
||
|
||
// IntracityQueryOrder 查询配送单
|
||
func (express *Express) IntracityQueryOrder(ctx context.Context, req *QueryOrderRequest) (res QueryOrderResponse, err error) {
|
||
accessToken, err := express.GetAccessToken()
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
uri := fmt.Sprintf(intracityQueryOrderURL, accessToken)
|
||
response, err := util.PostJSONContext(ctx, uri, req)
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
err = util.DecodeWithError(response, &res, "IntracityQueryOrder")
|
||
return
|
||
}
|
||
|
||
// CancelOrderRequest 取消配送单请求参数
|
||
type CancelOrderRequest struct {
|
||
WxOrderID string `json:"wx_order_id,omitempty"` // 微信订单号，二选一
|
||
OutOrderID string `json:"out_order_id,omitempty"` // 自定义订单号，二选一
|
||
WxStoreID string `json:"wx_store_id,omitempty"` // 微信门店编号
|
||
OutStoreID string `json:"out_store_id,omitempty"` // 自定义门店编号
|
||
CancelReason string `json:"cancel_reason,omitempty"` // 取消原因
|
||
}
|
||
|
||
// CancelOrderResponse 取消配送单返回参数
|
||
type CancelOrderResponse struct {
|
||
util.CommonError
|
||
WxOrderID string `json:"wx_order_id"` // 微信订单号
|
||
RefundAmount int32 `json:"refund_amount"` // 退款金额，单位：分
|
||
DeductAmount int32 `json:"deduct_amount"` // 扣除违约金，单位：分
|
||
}
|
||
|
||
// IntracityCancelOrder 取消配送单
|
||
func (express *Express) IntracityCancelOrder(ctx context.Context, req *CancelOrderRequest) (res CancelOrderResponse, err error) {
|
||
accessToken, err := express.GetAccessToken()
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
uri := fmt.Sprintf(intracityCancelOrderURL, accessToken)
|
||
response, err := util.PostJSONContext(ctx, uri, req)
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
err = util.DecodeWithError(response, &res, "IntracityCancelOrder")
|
||
return
|
||
}
|
||
|
||
// MockNotifyRequest 模拟配送回调请求参数（仅用于测试）
|
||
type MockNotifyRequest struct {
|
||
WxOrderID string `json:"wx_order_id"` // 微信订单号
|
||
DeliveryStatus IntracityDeliveryStatus `json:"delivery_status"` // 配送状态
|
||
}
|
||
|
||
// IntracityMockNotify 模拟配送回调（仅用于测试）
|
||
func (express *Express) IntracityMockNotify(ctx context.Context, req *MockNotifyRequest) error {
|
||
accessToken, err := express.GetAccessToken()
|
||
if err != nil {
|
||
return err
|
||
}
|
||
|
||
uri := fmt.Sprintf(intracityMockNotifyURL, accessToken)
|
||
response, err := util.PostJSONContext(ctx, uri, req)
|
||
if err != nil {
|
||
return err
|
||
}
|
||
|
||
return util.DecodeWithCommonError(response, "IntracityMockNotify")
|
||
}
|