274 lines
11 KiB
Go
274 lines
11 KiB
Go
package jd
|
|
|
|
import (
|
|
"strings"
|
|
|
|
"git.rosy.net.cn/baseapi/platformapi/autonavi"
|
|
"git.rosy.net.cn/baseapi/platformapi/jdapi"
|
|
"git.rosy.net.cn/baseapi/utils"
|
|
"git.rosy.net.cn/jx-callback/business/controller"
|
|
"git.rosy.net.cn/jx-callback/business/jxutils"
|
|
"git.rosy.net.cn/jx-callback/business/model"
|
|
"git.rosy.net.cn/jx-callback/business/scheduler"
|
|
"git.rosy.net.cn/jx-callback/business/util"
|
|
"git.rosy.net.cn/jx-callback/globals"
|
|
"git.rosy.net.cn/jx-callback/globals/api"
|
|
"git.rosy.net.cn/jx-callback/legacy/freshfood"
|
|
)
|
|
|
|
var (
|
|
VendorStatus2StatusMap = map[string]int{
|
|
jdapi.OrderStatusPurchased: model.OrderStatusNew,
|
|
jdapi.OrderStatusNew: model.OrderStatusNew,
|
|
jdapi.OrderStatusAdjust: model.OrderStatusNew,
|
|
jdapi.OrderStatusWaitOutStore: model.OrderStatusAccepted,
|
|
jdapi.OrderStatusFinishedPickup: model.OrderStatusFinishedPickup,
|
|
jdapi.OrderStatusDelivering: model.OrderStatusDelivering,
|
|
jdapi.OrderStatusDelivered: model.OrderStatusDelivered,
|
|
jdapi.OrderStatusCanceled: model.OrderStatusCanceled,
|
|
|
|
jdapi.OrderStatusUserApplyCancel: model.OrderStatusApplyCancel,
|
|
jdapi.OrderStatusLocked: model.OrderStatusLocked,
|
|
jdapi.OrderStatusUnlocked: model.OrderStatusUnlocked,
|
|
}
|
|
)
|
|
|
|
type OrderController struct {
|
|
scheduler.BasePurchasePlatform
|
|
}
|
|
|
|
func init() {
|
|
scheduler.CurrentScheduler.RegisterPurchasePlatform(model.VendorIDJD, new(OrderController))
|
|
}
|
|
|
|
func (c *OrderController) OnOrderMsg(msg *jdapi.CallbackOrderMsg) (retVal *jdapi.CallbackResponse) {
|
|
jxutils.CallMsgHandler(func() {
|
|
retVal = c.onOrderMsg(msg)
|
|
}, jxutils.ComposeUniversalOrderID(msg.BillID, model.VendorIDJD))
|
|
return retVal
|
|
}
|
|
|
|
func (c *OrderController) onOrderMsg(msg *jdapi.CallbackOrderMsg) (retVal *jdapi.CallbackResponse) {
|
|
if jdapi.OrderStatusNew == msg.StatusID {
|
|
retVal = c.onOrderNew(msg)
|
|
} else if jdapi.OrderStatusAdjust == msg.StatusID {
|
|
retVal = c.onOrderAdjust(msg)
|
|
} else {
|
|
status := c.callbackMsg2Status(msg)
|
|
if msg.StatusID == jdapi.OrderStatusAddComment || msg.StatusID == jdapi.OrderStatusModifyComment {
|
|
if globals.ReallyCallPlatformAPI {
|
|
freshfood.FreshFoodAPI.JDOrderComment(msg)
|
|
}
|
|
}
|
|
err := controller.OrderManager.OnOrderStatusChanged(status)
|
|
// if globals.HandleLegacyJxOrder && err == nil {
|
|
// c.legacyJdOrderStatusChanged(status)
|
|
// }
|
|
retVal = jdapi.Err2CallbackResponse(err, status.VendorStatus)
|
|
}
|
|
return retVal
|
|
}
|
|
|
|
func (c *OrderController) GetOrder(orderID string) (order *model.GoodsOrder, err error) {
|
|
result, err := api.JdAPI.QuerySingleOrder(orderID)
|
|
bussResult, bussErr := api.JdAPI.QueryOassBussMoney(orderID)
|
|
// globals.SugarLogger.Info(result)
|
|
//todo 将API获取的信息填入新字段里
|
|
if err == nil && bussErr == nil {
|
|
order = &model.GoodsOrder{
|
|
VendorOrderID: orderID,
|
|
VendorID: model.VendorIDJD,
|
|
VendorStoreID: result["produceStationNo"].(string),
|
|
StoreID: int(utils.Str2Int64WithDefault(utils.Interface2String(result["produceStationNoIsv"]), 0)),
|
|
StoreName: result["produceStationName"].(string),
|
|
ConsigneeName: utils.FilterMb4(result["buyerFullName"].(string)),
|
|
ConsigneeMobile: result["buyerMobile"].(string),
|
|
ConsigneeAddress: utils.FilterMb4(result["buyerFullAddress"].(string)),
|
|
CoordinateType: model.CoordinateTypeMars,
|
|
BuyerComment: utils.FilterMb4(strings.Trim(utils.Interface2String(result["orderBuyerRemark"]), "\n\r\t ")),
|
|
ExpectedDeliveredTime: utils.Str2TimeWithDefault(utils.Interface2String(result["orderPreEndDeliveryTime"]), utils.DefaultTimeValue),
|
|
VendorStatus: utils.Int64ToStr(utils.MustInterface2Int64(result["orderStatus"])),
|
|
OrderSeq: int(utils.MustInterface2Int64(result["orderNum"])),
|
|
StatusTime: utils.Str2Time(result["orderPurchaseTime"].(string)),
|
|
OriginalData: utils.FilterMb4(string(utils.MustMarshal(result))),
|
|
ActualPayPrice: utils.MustInterface2Int64(result["orderBuyerPayableMoney"]),
|
|
Skus: []*model.OrderSku{},
|
|
}
|
|
|
|
order.Status = c.GetStatusFromVendorStatus(order.VendorStatus)
|
|
businessTage := utils.Interface2String(result["businessTag"])
|
|
if strings.Index(businessTage, "dj_aging_immediately") >= 0 {
|
|
order.BusinessType = model.BusinessTypeImmediate
|
|
} else {
|
|
order.BusinessType = model.BusinessTypeDingshida
|
|
}
|
|
coordinateType := utils.Interface2Int64WithDefault(result["buyerCoordType"], 1)
|
|
originalLng := utils.MustInterface2Float64(result["buyerLng"])
|
|
originalLat := utils.MustInterface2Float64(result["buyerLat"])
|
|
if coordinateType == 1 {
|
|
lng, lat, err2 := api.AutonaviAPI.CoordinateConvert(originalLng, originalLat, autonavi.CoordSysGPS)
|
|
if err2 == nil {
|
|
originalLng = lng
|
|
originalLat = lat
|
|
} else {
|
|
// 如果没有转成功，保留原始数据
|
|
order.CoordinateType = model.CoordinateTypeGPS
|
|
}
|
|
}
|
|
order.ConsigneeLng = jxutils.StandardCoordinate2Int(originalLng)
|
|
order.ConsigneeLat = jxutils.StandardCoordinate2Int(originalLat)
|
|
// discounts := result["discount"].(map[string]interface{})
|
|
for _, product2 := range result["product"].([]interface{}) {
|
|
product := product2.(map[string]interface{})
|
|
sku := &model.OrderSku{
|
|
VendorOrderID: orderID,
|
|
VendorID: model.VendorIDJD,
|
|
Count: int(utils.MustInterface2Int64(product["skuCount"])),
|
|
SkuID: int(utils.Str2Int64WithDefault(utils.Interface2String(product["skuIdIsv"]), 0)),
|
|
VendorSkuID: utils.Int64ToStr(utils.MustInterface2Int64(product["skuId"])),
|
|
SkuName: product["skuName"].(string),
|
|
Weight: int(utils.MustInterface2Float64(product["skuWeight"]) * 1000),
|
|
SalePrice: utils.MustInterface2Int64(product["skuJdPrice"]),
|
|
PromotionType: int(utils.MustInterface2Int64(product["promotionType"])),
|
|
}
|
|
if product["isGift"].(bool) {
|
|
sku.SkuType = 1
|
|
}
|
|
order.Skus = append(order.Skus, sku)
|
|
order.SkuCount++
|
|
order.GoodsCount += sku.Count
|
|
order.SalePrice += sku.SalePrice * int64(sku.Count)
|
|
order.Weight += sku.Weight * sku.Count
|
|
}
|
|
}
|
|
setOrederDetailFee(bussResult, result, order)
|
|
return order, err
|
|
}
|
|
|
|
func setOrederDetailFee(bussResult []interface{}, result map[string]interface{}, order *model.GoodsOrder) {
|
|
var skuTotalPmFee, orderPmFee, skuTotalPmSubsidy, orderPmSubsidy int64
|
|
for _, value := range bussResult {
|
|
OassBussinessSkusNew := value.(map[string]interface{})
|
|
discountlist := OassBussinessSkusNew["discountlist"].([]interface{})
|
|
promotionType := utils.MustInterface2Int64(OassBussinessSkusNew["promotionType"])
|
|
skuId := utils.MustInterface2Int64(OassBussinessSkusNew["skuId"])
|
|
for _, value := range discountlist {
|
|
OrderBussiDiscountMoney := value.(map[string]interface{})
|
|
if isHave, _ := util.Contain(promotionType, model.JdSkuPromotion); isHave == true {
|
|
singleSkuPmFee := utils.MustInterface2Int64(OrderBussiDiscountMoney["saleMoney"])
|
|
skuTotalPmFee += singleSkuPmFee
|
|
singleSkuPmSubsidy := utils.MustInterface2Int64(OrderBussiDiscountMoney["costMoney"])
|
|
skuTotalPmSubsidy += singleSkuPmSubsidy
|
|
setSkuDetailFee(singleSkuPmFee, singleSkuPmSubsidy, order, skuId)
|
|
} else {
|
|
orderPmFee += utils.MustInterface2Int64(OrderBussiDiscountMoney["saleMoney"])
|
|
orderPmSubsidy += utils.MustInterface2Int64(OrderBussiDiscountMoney["costMoney"])
|
|
}
|
|
}
|
|
}
|
|
order.SkuTotalPmFee = skuTotalPmFee
|
|
order.OrderPmFee = orderPmFee
|
|
order.SkuTotalPmSubsidy = skuTotalPmSubsidy
|
|
order.OrderPmSubsidy = orderPmSubsidy
|
|
order.BoxFee = utils.MustInterface2Int64(result["packagingMoney"])
|
|
order.PlatformFeeRate = model.JdPlatformFeeRate
|
|
}
|
|
|
|
func setSkuDetailFee(skuPmFee int64, skuPmSubsidy int64, order *model.GoodsOrder, skuId int64) {
|
|
for _, value := range order.Skus {
|
|
if value.SkuID == int(skuId) {
|
|
value.SkuPmSubsidy = skuPmSubsidy
|
|
value.SkuPmFee = skuPmFee
|
|
}
|
|
}
|
|
}
|
|
|
|
//
|
|
func (c *OrderController) onOrderNew(msg *jdapi.CallbackOrderMsg) (response *jdapi.CallbackResponse) {
|
|
order, err := c.GetOrder(msg.BillID)
|
|
if err == nil {
|
|
err = controller.OrderManager.OnOrderNew(order, msg.StatusID)
|
|
// if err == nil {
|
|
// c.legacyWriteJdOrder(order, false)
|
|
// }
|
|
}
|
|
return jdapi.Err2CallbackResponse(err, "jd onOrderNew")
|
|
}
|
|
|
|
func (c *OrderController) onOrderAdjust(msg *jdapi.CallbackOrderMsg) *jdapi.CallbackResponse {
|
|
order, err := c.GetOrder(msg.BillID)
|
|
if err == nil {
|
|
err = controller.OrderManager.OnOrderAdjust(order, msg.StatusID)
|
|
// if globals.HandleLegacyJxOrder && err == nil {
|
|
// c.legacyWriteJdOrder(order, true)
|
|
// }
|
|
}
|
|
return jdapi.Err2CallbackResponse(err, "jd onOrderAdjust")
|
|
}
|
|
|
|
func (c *OrderController) callbackMsg2Status(msg *jdapi.CallbackOrderMsg) *model.OrderStatus {
|
|
orderStatus := &model.OrderStatus{
|
|
VendorOrderID: msg.BillID,
|
|
VendorID: model.VendorIDJD,
|
|
OrderType: model.OrderTypeOrder,
|
|
RefVendorOrderID: msg.BillID,
|
|
RefVendorID: model.VendorIDJD,
|
|
VendorStatus: msg.StatusID,
|
|
Status: c.GetStatusFromVendorStatus(msg.StatusID),
|
|
StatusTime: utils.Str2Time(msg.Timestamp),
|
|
Remark: msg.Remark,
|
|
}
|
|
return orderStatus
|
|
}
|
|
|
|
// PurchasePlatformHandler
|
|
func (c *OrderController) GetStatusFromVendorStatus(vendorStatus string) int {
|
|
if status, ok := VendorStatus2StatusMap[vendorStatus]; ok {
|
|
return status
|
|
}
|
|
return model.OrderStatusUnknown
|
|
}
|
|
|
|
func (c *OrderController) AcceptOrRefuseOrder(order *model.GoodsOrder, isAcceptIt bool) (err error) {
|
|
_, err = api.JdAPI.OrderAcceptOperate(order.VendorOrderID, isAcceptIt)
|
|
return err
|
|
}
|
|
|
|
func (c *OrderController) PickupGoods(order *model.GoodsOrder) (err error) {
|
|
_, err = api.JdAPI.OrderJDZBDelivery(order.VendorOrderID)
|
|
return err
|
|
}
|
|
|
|
func (c *OrderController) Swtich2SelfDeliver(order *model.GoodsOrder) (err error) {
|
|
_, err = api.JdAPI.ModifySellerDelivery(order.VendorOrderID)
|
|
if err != nil {
|
|
if errWithCode, ok := err.(*utils.ErrorWithCode); ok && errWithCode.Level() == 1 {
|
|
globals.SugarLogger.Infof("Swtich2SelfDeliver failed with error:%v try get current status", err)
|
|
if order2, err2 := c.GetOrder(order.VendorOrderID); err2 == nil {
|
|
var mapData map[string]interface{}
|
|
if err2 = utils.UnmarshalUseNumber([]byte(order2.OriginalData), &mapData); err2 == nil {
|
|
if utils.Interface2String(mapData["deliveryCarrierNo"]) == "2938" { // 当前已经是自送状态了
|
|
err = nil
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return err
|
|
}
|
|
|
|
func (c *OrderController) Swtich2SelfDelivered(order *model.GoodsOrder) (err error) {
|
|
_, err = api.JdAPI.DeliveryEndOrder(order.VendorOrderID)
|
|
return err
|
|
}
|
|
|
|
func (c *OrderController) SelfDeliverDelievering(order *model.GoodsOrder) (err error) {
|
|
_, err = api.JdAPI.OrderSerllerDelivery(order.VendorOrderID)
|
|
return err
|
|
}
|
|
|
|
// 京东送达接口都是一样的
|
|
func (c *OrderController) SelfDeliverDelievered(order *model.GoodsOrder) (err error) {
|
|
return c.Swtich2SelfDelivered(order)
|
|
}
|