From 99d4b4dd047fbd894d74979d8e49de1b417cea18 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com> Date: Fri, 12 Mar 2021 17:03:40 +0800 Subject: [PATCH] aa --- business/jxstore/cms/sync_store_sku.go | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/business/jxstore/cms/sync_store_sku.go b/business/jxstore/cms/sync_store_sku.go index 03f0d2615..e159d7ddc 100644 --- a/business/jxstore/cms/sync_store_sku.go +++ b/business/jxstore/cms/sync_store_sku.go @@ -927,16 +927,19 @@ func amendAndPruneStoreStuff(ctx *jxcontext.Context, parentTask tasksch.ITask, v step := batchItemList[0].(int) switch step { case 0: - if vendorID == model.VendorIDJDShop { - storeID = model.JdShopMainStoreID2 - } localSkuList, err := dao.GetStoreSkus2(db, vendorID, storeID, nil, false) if err != nil { return nil, err } localSkuMap := make(map[string]*dao.StoreSkuSyncInfo) for _, v := range localSkuList { - localSkuMap[v.VendorSkuID] = v + vendorSkuID := v.VendorSkuID + if vendorID == model.VendorIDJDShop { + if storeSkus, _ := dao.GetStoresSkusInfo(db, []int{model.JdShopMainStoreID2}, []int{v.SkuID}); len(storeSkus) > 0 { + vendorSkuID = utils.Int64ToStr(storeSkus[0].JdsID) + } + } + localSkuMap[vendorSkuID] = v } remoteSkuList, err2 := handler.GetStoreSkusFullInfo(ctx, task, storeID, vendorStoreID, nil)