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

京东商城店内分类修改

Browse Source
This commit is contained in:
苏尹岚
2020-05-27 17:04:53 +08:00
parent e58bc63c82
commit 7befc48561
3 changed files with 20 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
business/jxstore/cms/sync_store_sku.go
View File

@@ -335,7 +335,7 @@ func updateStoreSku(db *dao.DaoDB, vendorID int, storeSkuList []*dao.StoreSkuSyn
// } // }
// }() // }()
if vendorID == model.VendorIDJDShop { if vendorID == model.VendorIDJDShop {
if syncStatus != model.SyncFlagPriceMask { if syncStatus != model.SyncFlagPriceMask && syncStatus != model.SyncFlagSaleMask {
for _, v := range storeSkuList { for _, v := range storeSkuList {
updateItemList := make([]*dao.KVUpdateItem, len(v.StoreSkuSyncInfoJds)) updateItemList := make([]*dao.KVUpdateItem, len(v.StoreSkuSyncInfoJds))
for k, vv := range v.StoreSkuSyncInfoJds { for k, vv := range v.StoreSkuSyncInfoJds {

8
business/partner/purchase/jdshop/store.go
View File

@@ -68,10 +68,10 @@ func (p *PurchaseHandler) UpdateStore(db *dao.DaoDB, storeID int, userName strin
} }
err = api.JdShopAPI.UpdateEntityStore(updateEntityStoreParam) err = api.JdShopAPI.UpdateEntityStore(updateEntityStoreParam)
if err == nil { if err == nil {
if store.SyncStatus&(model.SyncFlagNewMask|model.SyncFlagStoreStatus) != 0 { // if store.SyncStatus&(model.SyncFlagNewMask|model.SyncFlagStoreStatus) != 0 {
mergeStatus := jxutils.MergeStoreStatus(store.Status, store.VendorStatus) // mergeStatus := jxutils.MergeStoreStatus(store.Status, store.VendorStatus)
err = api.JdShopAPI.UpdateStoreStatus(utils.Str2Int(store.VendorStoreID), jxStatus2JdsStatus(mergeStatus)) // err = api.JdShopAPI.UpdateStoreStatus(utils.Str2Int(store.VendorStoreID), jxStatus2JdsStatus(mergeStatus))
} // }
} }
return err return err
} }

22
business/partner/purchase/jdshop/store_sku.go
View File

@@ -1,6 +1,7 @@
package jdshop package jdshop
import ( import (
"fmt"
"regexp" "regexp"
"strings" "strings"
"time" "time"
@@ -303,7 +304,10 @@ func (p *PurchaseHandler) GetStoreAllCategories(ctx *jxcontext.Context, storeID
func (p *PurchaseHandler) CreateStoreCategory(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeCat *dao.SkuStoreCatInfo) (err error) { func (p *PurchaseHandler) CreateStoreCategory(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeCat *dao.SkuStoreCatInfo) (err error) {
if globals.EnableJdShopWrite && vendorStoreID == model.JdShopMainVendorStoreID { if globals.EnableJdShopWrite && vendorStoreID == model.JdShopMainVendorStoreID {
err = updateOrCreateCategories(storeCat, true) status, err := updateOrCreateCategories(storeCat, true)
if status == -1 {
return fmt.Errorf("京东商城店内分类创建失败！")
}
result, err := api.JdShopAPI.FindShopCategories() result, err := api.JdShopAPI.FindShopCategories()
if err != nil { if err != nil {
return err return err
@@ -320,7 +324,11 @@ func (p *PurchaseHandler) CreateStoreCategory(ctx *jxcontext.Context, storeID in
func (p *PurchaseHandler) UpdateStoreCategory(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeCat *dao.SkuStoreCatInfo) (err error) { func (p *PurchaseHandler) UpdateStoreCategory(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeCat *dao.SkuStoreCatInfo) (err error) {
if globals.EnableJdShopWrite && vendorStoreID == model.JdShopMainVendorStoreID { if globals.EnableJdShopWrite && vendorStoreID == model.JdShopMainVendorStoreID {
err = updateOrCreateCategories(storeCat, false) status, err2 := updateOrCreateCategories(storeCat, false)
err = err2
if status == -1 {
return fmt.Errorf("京东商城店内分类更新失败！")
}
} }
return err return err
} }
@@ -383,11 +391,11 @@ func vendorSku2Jx(result *jdshopapi.SearchWare4ValidResultData) (skuName *partne
return skuName return skuName
} }
func updateOrCreateCategories(storeCat *dao.SkuStoreCatInfo, isCreate bool) (err error) { func updateOrCreateCategories(storeCat *dao.SkuStoreCatInfo, isCreate bool) (status int64, err error) {
var createShopCategoryParams []*jdshopapi.CreateShopCategoryParam var createShopCategoryParams []*jdshopapi.CreateShopCategoryParam
result, err := api.JdShopAPI.FindShopCategories() result, err := api.JdShopAPI.FindShopCategories()
if err != nil { if err != nil {
return err return -1, err
} }
for _, v := range result { for _, v := range result {
createShopCategoryParam := &jdshopapi.CreateShopCategoryParam{ createShopCategoryParam := &jdshopapi.CreateShopCategoryParam{
@@ -410,7 +418,7 @@ func updateOrCreateCategories(storeCat *dao.SkuStoreCatInfo, isCreate bool) (err
} }
if isCreate { if isCreate {
createShopCategoryParam2.Type = jdshopapi.CreateCatType createShopCategoryParam2.Type = jdshopapi.CreateCatType
createShopCategoryParam2.ID = "0" createShopCategoryParam2.ID = "1"
createShopCategoryParams = append(createShopCategoryParams, createShopCategoryParam2) createShopCategoryParams = append(createShopCategoryParams, createShopCategoryParam2)
} else { } else {
for _, v := range createShopCategoryParams { for _, v := range createShopCategoryParams {
@@ -420,8 +428,8 @@ func updateOrCreateCategories(storeCat *dao.SkuStoreCatInfo, isCreate bool) (err
} }
} }
} }
err = api.JdShopAPI.CreateShopCategory(createShopCategoryParams) status, err = api.JdShopAPI.CreateShopCategory(createShopCategoryParams)
return err return status, err
} }
func buildCreateWareParam(storeSku *dao.StoreSkuSyncInfo) (createSkuParamWare *jdshopapi.CreateSkuParamWare, createSkuParamSkus []*jdshopapi.CreateSkuParamSkus, err error) { func buildCreateWareParam(storeSku *dao.StoreSkuSyncInfo) (createSkuParamWare *jdshopapi.CreateSkuParamWare, createSkuParamSkus []*jdshopapi.CreateSkuParamSkus, err error) {