449 lines
16 KiB
Go
449 lines
16 KiB
Go
package jdapi
|
||
|
||
import (
|
||
"errors"
|
||
"strings"
|
||
|
||
"git.rosy.net.cn/baseapi"
|
||
|
||
"git.rosy.net.cn/baseapi/utils"
|
||
)
|
||
|
||
const (
|
||
AfsPicPrefix = "http://img10.360buyimg.com/o2o"
|
||
)
|
||
|
||
const (
|
||
DeliveryStatusWait4Grap = "10"
|
||
DeliveryStatusAccepted = "20"
|
||
DeliveryStatusCourierCanceled = "21"
|
||
DeliveryStatusCourierArrived = "23"
|
||
DeliveryStatusFailedGetGoods = "25"
|
||
DeliveryStatusFailedGetGoodsRejected = "26"
|
||
DeliveryStatusFailedGetGoodsWaiting = "27"
|
||
DeliveryStatusGotGoods = "30"
|
||
DeliveryStatusFailedDelivery = "35"
|
||
DeliveryStatusFinished = "40"
|
||
)
|
||
|
||
const (
|
||
PromotionTypeNormal = 1
|
||
PromotionTypeSeckill = 2
|
||
PromotionTypeDirectDown = 3
|
||
PromotionTypeLimitedTime = 4
|
||
PromotionTypeAddMoneyBuy = 1202
|
||
PromotionTypeOverflowGiveGift = 1203
|
||
PromotionTypeBuyGiveGift = 6
|
||
)
|
||
|
||
const (
|
||
FreightDiscountTypeByShop = 8 // 8:商家满免运费
|
||
FreightDiscountTypeByVip = 7 // 7:VIP免运费
|
||
FreightDiscountTypeByActivity = 12 // 12:首单地推满免运费
|
||
FreightDiscountTypeByCoupons = 15 // 15:运费券
|
||
SelfDeliveryCarrierNo = "2938" // 京东配送方式=商家自送
|
||
)
|
||
|
||
const (
|
||
UserApplyCancelWaitMinute = 15 // 用户申请取消订单后待处理的最大等待时间（分钟），超时自动同意
|
||
)
|
||
|
||
const (
|
||
QueryOrderRetryCount = 1 // 因为京东到家当前不存在的订单也返回-4，暂时不重试
|
||
)
|
||
|
||
const (
|
||
AfsApproveTypeRefund = 1 // 退款
|
||
AfsApproveTypeReturnGoods = 2 // 退货
|
||
AfsApproveTypeRefused = 3 // 驳回
|
||
)
|
||
|
||
const (
|
||
AfsReasonTypeGoodsQuality = 201 // 商品质量问题/做工粗糙/有瑕疵
|
||
AfsReasonTypeWrongGoods = 202 // 发错货
|
||
AfsReasonTypeMissingGoods = 203 // 部分商品未收到
|
||
AfsReasonTypeNoGoods = 501 // 全部商品未收到
|
||
AfsReasonTypeDamagedGoods = 208 // 外表损伤（压坏,磕坏等）
|
||
AfsReasonTypeGoodsQuantity = 207 // 缺斤少两
|
||
AfsReasonTypeAgreedByMerchant = 209 // 与商家协商一致
|
||
AfsReasonTypeGoodsSizeNoSame = 302 // 大小尺寸与商品描述不符
|
||
AfsReasonTypeGoodsColorNoSame = 303 // 颜色/款式/图案与描述不符
|
||
AfsReasonWrongPurchase = 402 // 误购
|
||
AfsReasonNotReceivedIntime = 502 // 未在时效内送达
|
||
)
|
||
|
||
const (
|
||
AfsDealTypeRefund = "10" // 仅退款
|
||
AfsDealTypeDirectCompensate = "30" // 直赔
|
||
AfsDealTypeReturnGoodsRefund = "40" // 退货退款
|
||
)
|
||
|
||
type AfsSkuDiscount struct {
|
||
DetailDiscountType int `json:"detailDiscountType"`
|
||
DiscountType int `json:"discountType"`
|
||
PlatPayMoney int64 `json:"platPayMoney"`
|
||
VenderPayMoney int64 `json:"venderPayMoney"`
|
||
}
|
||
|
||
type AfsServiceDetail struct {
|
||
SkuIDIsv string `json:"skuIdIsv"`
|
||
WareID int64 `json:"wareId"`
|
||
WareName string `json:"wareName"`
|
||
WareNum int `json:"wareNum"`
|
||
|
||
AfsMoney int64 `json:"afsMoney"`
|
||
PlatPayMoney int64 `json:"platPayMoney"`
|
||
|
||
AfsSkuDiscountList []*AfsSkuDiscount `json:"afsSkuDiscountList"`
|
||
}
|
||
|
||
type AfsServiceResponse struct {
|
||
AfsServiceID int64 `json:"afsServiceId"`
|
||
AfsServiceOrder string `json:"afsServiceOrder"`
|
||
AfsServiceState int `json:"afsServiceState"`
|
||
CreateTime *utils.JavaDate `json:"createTime"`
|
||
UpdateTime *utils.JavaDate `json:"updateTime"`
|
||
CustomerMobilePhone string `json:"customerMobilePhone"`
|
||
CustomerName string `json:"customerName"`
|
||
OrderID string `json:"orderId"`
|
||
OrderSource int `json:"orderSource"`
|
||
OrderStatus int `json:"orderStatus"`
|
||
OrderType int `json:"orderType"`
|
||
PickwareAddress string `json:"pickwareAddress"`
|
||
|
||
OrderFreightMoney int64 `json:"orderFreightMoney"`
|
||
AfsFreight int64 `json:"afsFreight"`
|
||
PackagingMoney int64 `json:"packagingMoney"`
|
||
TongchengFreightMoney int64 `json:"tongchengFreightMoney"`
|
||
MealBoxMoney int64 `json:"mealBoxMoney"`
|
||
|
||
QuestionDesc string `json:"questionDesc"`
|
||
QuestionPic string `json:"questionPic"`
|
||
QuestionTypeCid int `json:"questionTypeCid"`
|
||
|
||
ApplyDeal string `json:"applyDeal"`
|
||
DeliveryState string `json:"deliveryState"`
|
||
DeliveryMan string `json:"deliveryMan"`
|
||
DeliveryMobile string `json:"deliveryMobile"`
|
||
|
||
StationID string `json:"stationId"`
|
||
StationName string `json:"stationName"`
|
||
StationNumOutSystem string `json:"stationNumOutSystem"`
|
||
VenderID string `json:"venderId"`
|
||
|
||
AfsDetailList []*AfsServiceDetail `json:"afsDetailList"`
|
||
}
|
||
|
||
type OAOSAdjustDTO struct {
|
||
SkuID int64 `json:"skuId,omitempty"`
|
||
OutSkuID string `json:"outSkuId,omitempty"`
|
||
SkuCount int `json:"skuCount"`
|
||
}
|
||
|
||
type VenderAfsSkuDTO struct {
|
||
SkuID int64 `json:"skuId"`
|
||
SkuCount int `json:"skuCount"`
|
||
PromotionType int `json:"promotionType"`
|
||
}
|
||
|
||
var (
|
||
ErrCanNotFindOrder = errors.New("can not find order")
|
||
)
|
||
|
||
var (
|
||
orderOperationResultParser = genNoPageResultParser("code", "msg", "detail", "0")
|
||
)
|
||
|
||
// 订单列表查询接口
|
||
// https://opendj.jd.com/staticnew/widgets/resources.html?groupid=169&apiid=ba3027848c3c4fda9674966e2a466482
|
||
func (a *API) OrderQuery(jdParams map[string]interface{}) (retVal []interface{}, totalCount int, err error) {
|
||
// 最多试三次
|
||
for i := 0; i < QueryOrderRetryCount; i++ {
|
||
retVal, totalCount, err = a.AccessAPIHavePage("order/es/query", jdParams, nil, nil, nil)
|
||
if err != nil {
|
||
if err2, ok := err.(*utils.ErrorWithCode); ok {
|
||
if err2.IntCode() == -4 {
|
||
continue
|
||
}
|
||
}
|
||
}
|
||
break
|
||
}
|
||
return retVal, totalCount, err
|
||
}
|
||
|
||
// orderFreightMoney 基础运费
|
||
// tips 商家承担小费
|
||
// merchantPaymentDistanceFreightMoney 取件服务费(开票)(正向单展示远距离运费;售后单则展示达达售后运费)
|
||
// orderBaseFreightMoney ?
|
||
func (a *API) QuerySingleOrder(orderId string) (map[string]interface{}, error) {
|
||
jdParams := make(map[string]interface{})
|
||
jdParams["orderId"] = orderId
|
||
result, _, err := a.OrderQuery(jdParams)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
if len(result) == 0 {
|
||
return nil, ErrCanNotFindOrder
|
||
}
|
||
return result[0].(map[string]interface{}), nil
|
||
}
|
||
|
||
func (a *API) LegacyQuerySingleOrder(orderId string) (map[string]interface{}, error) {
|
||
jdParams := make(map[string]interface{})
|
||
jdParams["orderId"] = orderId
|
||
|
||
result, err := a.AccessAPI("order/es/query", jdParams)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
dataStr, _ := result["data"].(string)
|
||
var data map[string]interface{}
|
||
utils.UnmarshalUseNumber([]byte(dataStr), &data)
|
||
result["data"] = data
|
||
|
||
var dataResult map[string]interface{}
|
||
utils.UnmarshalUseNumber([]byte(data["result"].(string)), &dataResult)
|
||
data["result"] = dataResult
|
||
|
||
return result, nil
|
||
}
|
||
|
||
// 商家确认接单接口
|
||
// https://opendj.jd.com/staticnew/widgets/resources.html?groupid=169&apiid=c1a15129d1374e9da7fa35487f878604
|
||
func (a *API) OrderAcceptOperate(orderId string, isAgreed bool, userName string) error {
|
||
jdParams := map[string]interface{}{
|
||
"orderId": orderId,
|
||
"isAgreed": utils.Bool2String(isAgreed),
|
||
"operator": utils.GetAPIOperator(userName),
|
||
}
|
||
_, err := a.AccessAPINoPage("ocs/orderAcceptOperate", jdParams, nil, nil, orderOperationResultParser)
|
||
return err
|
||
}
|
||
|
||
// 拣货完成且众包配送接口
|
||
// https://opendj.jd.com/staticnew/widgets/resources.html?groupid=169&apiid=ed93745b86c6487eaaea5f55a84785ac
|
||
func (a *API) OrderJDZBDelivery(orderId string, userName string) (detail string, err error) {
|
||
jdParams := map[string]interface{}{
|
||
"orderId": orderId,
|
||
"operator": utils.GetAPIOperator(userName),
|
||
}
|
||
result, err := a.AccessAPINoPage("bm/open/api/order/OrderJDZBDelivery", jdParams, nil, nil, orderOperationResultParser)
|
||
if err == nil {
|
||
return utils.Interface2String(result), nil
|
||
}
|
||
return "", err
|
||
}
|
||
|
||
// 订单达达配送转商家自送接口
|
||
// https://opendj.jd.com/staticnew/widgets/resources.html?groupid=169&apiid=e7b4950164754eecac7ea87278c2b071
|
||
func (a *API) ModifySellerDelivery(orderId string, userName string) (detail string, err error) {
|
||
jdParams := map[string]interface{}{
|
||
"orderId": orderId,
|
||
"updatePin": utils.GetAPIOperator(userName),
|
||
}
|
||
result, err := a.AccessAPINoPage("order/modifySellerDelivery", jdParams, nil, nil, orderOperationResultParser)
|
||
if err == nil {
|
||
return utils.Interface2String(result), nil
|
||
}
|
||
return "", err
|
||
}
|
||
|
||
// 拣货完成且商家自送接口（这个接口是商家本身配置为自送模式下才能调用的接口，如果启用了达达配送，是不能调用的）
|
||
// https://opendj.jd.com/staticnew/widgets/resources.html?groupid=169&apiid=0e08e71a45dc48b6a337e06a852ac33a
|
||
func (a *API) OrderSerllerDelivery(orderId string, userName string) (detail string, err error) {
|
||
jdParams := map[string]interface{}{
|
||
"orderId": orderId,
|
||
"operator": utils.GetAPIOperator(userName),
|
||
}
|
||
result, err := a.AccessAPINoPage("bm/open/api/order/OrderSerllerDelivery", jdParams, nil, nil, orderOperationResultParser)
|
||
if err == nil {
|
||
return utils.Interface2String(result), nil
|
||
}
|
||
return "", err
|
||
}
|
||
|
||
// 商家自送，订单妥投接口
|
||
// https://opendj.jd.com/staticnew/widgets/resources.html?groupid=169&apiid=ecc80f06d35141979f4841f345001f74
|
||
func (a *API) DeliveryEndOrder(orderId string, userName string) (result map[string]interface{}, err error) {
|
||
jdParams := map[string]interface{}{
|
||
"orderId": orderId,
|
||
"operPin": utils.GetAPIOperator(userName),
|
||
"operTime": utils.GetCurTimeStr(),
|
||
}
|
||
tmpResult, err := a.AccessAPINoPage("ocs/deliveryEndOrder", jdParams, nil, nil, nil)
|
||
if err == nil {
|
||
return tmpResult.(map[string]interface{}), nil
|
||
}
|
||
return nil, err
|
||
}
|
||
|
||
// 常规订单应结金额接口
|
||
// https://openo2o.jddj.com/staticnew/widgets/resources.html?groupid=169&apiid=17f0b596df554fe2b66fa7742a025d92
|
||
func (a *API) OrderShoudSettlementService(orderId string) (map[string]interface{}, error) {
|
||
jdParams := map[string]interface{}{
|
||
"orderId": orderId,
|
||
}
|
||
result, err := a.AccessAPINoPage("bill/orderShoudSettlementService", jdParams, nil, nil, genNoPageResultParser("code", "detail", "result", "0"))
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
if result == nil {
|
||
return nil, utils.NewErrorIntCode("查询订单信息异常", -4)
|
||
}
|
||
return result.(map[string]interface{}), nil
|
||
}
|
||
|
||
// 查询售后单详情接口
|
||
// https://openo2o.jddj.com/staticnew/widgets/resources.html?groupid=170&apiid=6805ed690b7b4776b058067312c57d98
|
||
func (a *API) GetAfsService(orderId string) (map[string]interface{}, error) {
|
||
jdParams := map[string]interface{}{
|
||
"afsServiceOrder": orderId,
|
||
}
|
||
result, err := a.AccessAPINoPage("afs/getAfsService", jdParams, nil, nil, genNoPageResultParser("code", "msg", "result", "0"))
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
return result.(map[string]interface{}), nil
|
||
}
|
||
|
||
func (a *API) GetAfsService2(afsOrderID string) (afsOrderInfo *AfsServiceResponse, err error) {
|
||
result, err := a.GetAfsService(afsOrderID)
|
||
if err == nil {
|
||
if err = utils.Map2StructByJson(result, &afsOrderInfo, false); err != nil {
|
||
baseapi.SugarLogger.Warnf("GetAfsService2, result:%s failed with error:%v", utils.Format4Output(result, true), err)
|
||
}
|
||
}
|
||
return afsOrderInfo, err
|
||
}
|
||
|
||
// 商家审核用户取消申请接口
|
||
// https://openo2o.jddj.com/staticnew/widgets/resources.html?groupid=169&apiid=906b430307764a3ca3698c05c72f33d0
|
||
func (a *API) OrderCancelOperate(orderId string, isAgreed bool, operator, remark string) (err error) {
|
||
jdParams := map[string]interface{}{
|
||
"orderId": orderId,
|
||
"isAgreed": isAgreed,
|
||
"operator": operator,
|
||
"remark": remark,
|
||
}
|
||
_, err = a.AccessAPINoPage("ocs/orderCancelOperate", jdParams, nil, nil, nullResultParser)
|
||
return err
|
||
}
|
||
|
||
// 订单调整接口
|
||
// https://openo2o.jddj.com/staticnew/widgets/resources.html?groupid=169&apiid=a7378109fd7243eea9efbb6231a7401c
|
||
func (a *API) AdjustOrder(orderId, operPin, remark string, oaosAdjustDTOList []*OAOSAdjustDTO) (err error) {
|
||
jdParams := map[string]interface{}{
|
||
"orderId": orderId,
|
||
"operPin": operPin,
|
||
"remark": remark,
|
||
"oaosAdjustDTOList": oaosAdjustDTOList,
|
||
}
|
||
_, err = a.AccessAPINoPage("orderAdjust/adjustOrder", jdParams, nil, nil, genNoPageResultParser("code", "detail", "", "0"))
|
||
return err
|
||
}
|
||
|
||
// 商家审核配送员取货失败接口
|
||
// https://openo2o.jddj.com/staticnew/widgets/resources.html?groupid=169&apiid=d10c63a2ea734b818b23f0bc1c8efe6f
|
||
func (a *API) ReceiveFailedAudit(orderId string, isAgreed bool, operator, remark string) (err error) {
|
||
jdParams := map[string]interface{}{
|
||
"orderId": orderId,
|
||
"isAgreed": isAgreed,
|
||
"operator": operator,
|
||
"remark": remark,
|
||
}
|
||
_, err = a.AccessAPINoPage("order/receiveFailedAudit", jdParams, nil, nil, nullResultParser)
|
||
return err
|
||
}
|
||
|
||
// 催配送员抢单接口
|
||
// https://openo2o.jddj.com/staticnew/widgets/resources.html?groupid=169&apiid=96383a8274bd463a95dfc8b8d74220d1
|
||
func (a *API) UrgeDispatching(orderId, updatePin string) (err error) {
|
||
jdParams := map[string]interface{}{
|
||
"orderId": orderId,
|
||
"updatePin": updatePin,
|
||
}
|
||
_, err = a.AccessAPINoPage("bm/urgeDispatching", jdParams, nil, nil, nullResultParser)
|
||
return err
|
||
}
|
||
|
||
// 商家确认收到拒收退回（或取消）的商品接口
|
||
// https://openo2o.jddj.com/staticnew/widgets/resources.html?groupid=169&apiid=21a55807c096410c9cac9b71e110fa43
|
||
func (a *API) ConfirmReceiveGoods(orderId string) (err error) {
|
||
jdParams := map[string]interface{}{
|
||
"orderId": orderId,
|
||
"operateTime": utils.GetCurTimeStr(),
|
||
}
|
||
_, err = a.AccessAPINoPage("order/confirmReceiveGoods", jdParams, nil, nil, nullResultParser)
|
||
return err
|
||
}
|
||
|
||
// 申请售后单审核接口
|
||
// https://openo2o.jddj.com/staticnew/widgets/resources.html?groupid=170&apiid=1690f6efc0144d59823b236e0d8506a1
|
||
func (a *API) AfsOpenApprove(afsOrderID string, afsApproveType int, rejectReason string, optPin string) (err error) {
|
||
jdParams := map[string]interface{}{
|
||
"serviceOrder": afsOrderID,
|
||
"approveType": afsApproveType,
|
||
"optPin": optPin,
|
||
}
|
||
if rejectReason != "" {
|
||
jdParams["rejectReason"] = rejectReason
|
||
}
|
||
_, err = a.AccessAPINoPage("afs/afsOpenApprove", jdParams, nil, nil, nullResultParser)
|
||
return err
|
||
}
|
||
|
||
// 售后单确认收货接口
|
||
// https://openo2o.jddj.com/staticnew/widgets/resources.html?groupid=170&apiid=4826086e81934405980ae26f80d956e0
|
||
func (a *API) ConfirmReceipt(afsOrderID, pin string) (err error) {
|
||
jdParams := map[string]interface{}{
|
||
"serviceOrder": afsOrderID,
|
||
"pin": pin,
|
||
}
|
||
_, err = a.AccessAPINoPage("afs/confirmReceipt", jdParams, nil, nil, nullResultParser)
|
||
return err
|
||
}
|
||
|
||
// 商家自主发起售后接口
|
||
// https://openo2o.jddj.com/staticnew/widgets/resources.html?groupid=170&apiid=b8d1ddacb03846a8a2e78c79723c752f
|
||
func (a *API) AfsSubmit(OrderID, pin, questionTypeCode, questionDesc, questionPic, customerName, customerMobilePhone, address string, skuList []*VenderAfsSkuDTO) (afsOrderID string, err error) {
|
||
jdParams := map[string]interface{}{
|
||
"orderId": OrderID,
|
||
"pin": pin,
|
||
"questionTypeCode": questionTypeCode,
|
||
}
|
||
if questionDesc != "" {
|
||
jdParams["questionDesc"] = questionDesc
|
||
}
|
||
if questionPic != "" {
|
||
jdParams["questionPic"] = questionPic
|
||
}
|
||
if customerName != "" {
|
||
jdParams["customerName"] = customerName
|
||
}
|
||
if customerMobilePhone != "" {
|
||
jdParams["customerMobilePhone"] = customerMobilePhone
|
||
}
|
||
if address != "" {
|
||
jdParams["address"] = address
|
||
}
|
||
result, err := a.AccessAPINoPage("afs/submit", jdParams, nil, nil, genNoPageResultParser("code", "msg", "result", "0"))
|
||
if err == nil {
|
||
afsOrderID = utils.Interface2String(result.(map[string]interface{})["serviceOrder"])
|
||
}
|
||
return afsOrderID, err
|
||
}
|
||
|
||
func ProcessQuestionPic(questionPic string) (outQuestionPic string) {
|
||
if questionPic != "" {
|
||
picList := strings.Split(questionPic, ",")
|
||
picList2 := make([]string, len(picList))
|
||
for index, pic := range picList {
|
||
picList2[index] = AfsPicPrefix + "/" + pic
|
||
}
|
||
outQuestionPic = strings.Join(picList2, ",")
|
||
}
|
||
return outQuestionPic
|
||
}
|