aa

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)