liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2023-06-30 11:56:36 +08:00
parent 0e93970cd8
commit d0b8bb3e9e
4 changed files with 39 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
business/partner/purchase/tao_vegetable/financial.go
View File

@@ -168,7 +168,7 @@ func (p *PurchaseHandler) OrderDetail2Financial(result *domain591.AlibabaAelophy
SkuID: utils.Str2Int(*x.SkuCode), SkuID: utils.Str2Int(*x.SkuCode),
Name: utils.Interface2String(x.SkuName), Name: utils.Interface2String(x.SkuName),
SalePrice: *x.Price, SalePrice: *x.Price,
Count: utils.Str2Int(*x.BuySaleQuantity), Count: utils.Float64TwoInt(*x.BuySaleQuantity),
SkuBoxMoney: 0, SkuBoxMoney: 0,
IsAfsOrder: 0, IsAfsOrder: 0,
} }

48
business/partner/purchase/tao_vegetable/order.go
View File

@@ -56,6 +56,7 @@ func (p *PurchaseHandler) getOrder(vendorOrgCode string, vendorOrderID int64, ve
BizOrderId: utils.Int64ToPointer(vendorOrderID), BizOrderId: utils.Int64ToPointer(vendorOrderID),
}} }}
orderDetail, err := getAPI(vendorOrgCode, 0, vendorStoreID).QueryOrderDetail(requestParam) orderDetail, err := getAPI(vendorOrgCode, 0, vendorStoreID).QueryOrderDetail(requestParam)
globals.SugarLogger.Debugf("orderDetail := %s", utils.Format4Output(orderDetail, false))
if err != nil { if err != nil {
return nil, nil, err return nil, nil, err
} }
@@ -105,13 +106,13 @@ func (p *PurchaseHandler) getOrder(vendorOrgCode string, vendorOrderID int64, ve
VendorID: model.VendorIDTaoVegetable, VendorID: model.VendorIDTaoVegetable,
StoreSubID: 0, StoreSubID: 0,
StoreSubName: "", StoreSubName: "",
Count: utils.Str2Int(*extra.BuySaleQuantity), Count: utils.Float64TwoInt(*extra.BuySaleQuantity),
VendorSkuID: *extra.SkuCode, VendorSkuID: *extra.SkuCode,
SkuID: utils.Str2Int(*extra.SkuCode), SkuID: utils.Str2Int(*extra.SkuCode),
JxSkuID: utils.Str2Int(*extra.SkuCode), JxSkuID: utils.Str2Int(*extra.SkuCode),
SkuName: *extra.SkuName, SkuName: *extra.SkuName,
ShopPrice: *extra.Price, ShopPrice: *extra.Price,
VendorPrice: *extra.OriginalFee / utils.Str2Int64(*extra.BuySaleQuantity), VendorPrice: *extra.OriginalFee / utils.Float64TwoInt64(*extra.BuySaleQuantity),
SalePrice: *extra.OriginalFee, SalePrice: *extra.OriginalFee,
EarningPrice: 0, EarningPrice: 0,
Weight: int(*extra.Weight), Weight: int(*extra.Weight),
@@ -124,23 +125,26 @@ func (p *PurchaseHandler) getOrder(vendorOrgCode string, vendorOrderID int64, ve
activityId := make([]int64, 0) activityId := make([]int64, 0)
activityName := make([]string, 0) activityName := make([]string, 0)
for _, v := range *extra.Activitys { if extra.Activitys != nil {
// 渠道活动 for _, v := range *extra.Activitys {
if v.ChannelActivityId != nil { // 渠道活动
activityId = append(activityId, utils.Str2Int64WithDefault(*v.ChannelActivityId, 999)) if v.ChannelActivityId != nil {
activityName = append(activityName, *v.ChannelActivityId+":"+*v.ActivityName) activityId = append(activityId, utils.Str2Int64WithDefault(*v.ChannelActivityId, 999))
} activityName = append(activityName, *v.ChannelActivityId+":"+*v.ActivityName)
// 业务活动 }
if v.BizActivityId != nil { // 业务活动
activityId = append(activityId, utils.Str2Int64WithDefault(*v.BizActivityId, 999)) if v.BizActivityId != nil {
activityName = append(activityName, *v.BizActivityId+":"+*v.ActivityName) activityId = append(activityId, utils.Str2Int64WithDefault(*v.BizActivityId, 999))
} activityName = append(activityName, *v.BizActivityId+":"+*v.ActivityName)
// 商家erp活动 }
if v.MerchantActivityId != nil { // 商家erp活动
activityId = append(activityId, utils.Str2Int64WithDefault(*v.MerchantActivityId, 999)) if v.MerchantActivityId != nil {
activityName = append(activityName, *v.MerchantActivityId+":"+*v.ActivityName) activityId = append(activityId, utils.Str2Int64WithDefault(*v.MerchantActivityId, 999))
activityName = append(activityName, *v.MerchantActivityId+":"+*v.ActivityName)
}
} }
} }
if len(activityId) > 0 { if len(activityId) > 0 {
sku.StoreSubID = int(activityId[0]) sku.StoreSubID = int(activityId[0])
sku.StoreSubName = strings.Join(activityName, ",") sku.StoreSubName = strings.Join(activityName, ",")
@@ -155,9 +159,11 @@ func (p *PurchaseHandler) getOrder(vendorOrgCode string, vendorOrderID int64, ve
} }
// 淘宝默认自配送 // 淘宝默认自配送
if *orderDetail.DeliveryType == tao_vegetable.OrderDeliveryTypeTime { if *orderDetail.DeliveryType == tao_vegetable.OrderDeliveryTypeTime {
order.DeliveryType = model.OrderDeliveryTypeStoreSelf order.DeliveryType = model.OrderDeliveryTypePlatform
} else if *orderDetail.DeliveryType == tao_vegetable.OrderDeliveryTypeSelf { } else if *orderDetail.DeliveryType == tao_vegetable.OrderDeliveryTypeSelf {
order.DeliveryType = model.OrderDeliveryTypeSelfTake order.DeliveryType = model.OrderDeliveryTypeSelfTake
} else if *orderDetail.DeliveryType == tao_vegetable.OrderDeliveryTypeStore {
order.DeliveryType = model.OrderDeliveryTypeStoreSelf
} }
// 期望送达时间两小时内为立即达 // 期望送达时间两小时内为立即达
@@ -198,7 +204,11 @@ func (p *PurchaseHandler) getOrder(vendorOrgCode string, vendorOrderID int64, ve
// 包装袋金额 // 包装袋金额
store, _ := dao.GetStoreDetail(dao.GetDB(), order.JxStoreID, order.VendorID, order.VendorOrgCode) store, _ := dao.GetStoreDetail(dao.GetDB(), order.JxStoreID, order.VendorID, order.VendorOrgCode)
order.PackagePrice = int(*orderDetail.PackageFee) + store.PackageSetting if store != nil {
order.PackagePrice = int(*orderDetail.PackageFee) + store.PackageSetting
} else {
order.PackagePrice = int(*orderDetail.PackageFee)
}
order.StoreName = store.Name // 真实门店名称 order.StoreName = store.Name // 真实门店名称
return order, orderMap, err return order, orderMap, err

2
business/partner/purchase/tao_vegetable/order_afs.go
View File

@@ -118,7 +118,7 @@ func (c *PurchaseHandler) onAfsOrderMsg(status string, msg interface{}) (retVal
} }
for _, sku := range *skuList.SubOrderResponseList { for _, sku := range *skuList.SubOrderResponseList {
orderSku := &model.OrderSkuFinancial{ orderSku := &model.OrderSkuFinancial{
Count: utils.Str2Int(*sku.BuySaleQuantity), Count: utils.Float64TwoInt(*sku.BuySaleQuantity),
VendorSkuID: *sku.SkuCode, VendorSkuID: *sku.SkuCode,
SkuID: utils.Str2Int(*sku.SkuCode), SkuID: utils.Str2Int(*sku.SkuCode),
Name: *sku.SkuName, Name: *sku.SkuName,

9
globals/api/apimanager/apimanager.go
View File

@@ -1,6 +1,7 @@
package apimanager package apimanager
import ( import (
"encoding/json"
"git.rosy.net.cn/baseapi/platformapi/jdapi" "git.rosy.net.cn/baseapi/platformapi/jdapi"
"git.rosy.net.cn/baseapi/platformapi/tao_vegetable" "git.rosy.net.cn/baseapi/platformapi/tao_vegetable"
"git.rosy.net.cn/baseapi/platformapi/tiktok_shop/tiktok_api" "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/tiktok_api"
@@ -74,7 +75,13 @@ func (a *APIManager) GetAPI(vendorID int, appOrgCode string) (pfAPI interface{})
} }
code := codes[0] code := codes[0]
api = tao_vegetable.NewTaoVegetable(code.AppKey, code.AppSecret, beego.AppConfig.DefaultString("taoVegetableServerUrl", "")) api = tao_vegetable.NewTaoVegetable(code.AppKey, code.AppSecret, beego.AppConfig.DefaultString("taoVegetableServerUrl", ""))
api.SetToken(code.Token) if code.Token != "" {
var tokenInfo *tao_vegetable.StoreTokenInfo
json.Unmarshal([]byte(code.Token), &tokenInfo)
if tokenInfo.AccessToken != "" {
api.SetToken(tokenInfo.AccessToken)
}
}
} }
pfAPI = api pfAPI = api