diff --git a/business/jxstore/cms/sync_store_sku.go b/business/jxstore/cms/sync_store_sku.go index 4cc70c14d..816063bdd 100644 --- a/business/jxstore/cms/sync_store_sku.go +++ b/business/jxstore/cms/sync_store_sku.go @@ -499,27 +499,11 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag } isContinueWhenError2 := true //如果是银豹平台,则要按照商品skuname维度同步 - var changeList2Yb = func(list1 []*dao.StoreSkuSyncInfo, list2 []*partner.StoreSkuInfo) { - var ( - skuNameMap = make(map[int]*dao.StoreSkuSyncInfo) - ) - for _, v := range list1 { - skuNameMap[v.NameID] = v - } - list1 = list1[0:0] - for _, v := range skuNameMap { - fmt.Println(utils.Format4Output(v, false)) - list1 = append(list1, v) - } - for _, v := range list1 { - v.YbBarCode = storeDetail.YbStorePrefix + v.YbNameSuffix - } - } if vendorID == model.VendorIDYB { // createList, updateList []*dao.StoreSkuSyncInfo // deleteList, stockList, onlineList, offlineList, priceList []*partner.StoreSkuInfo if len(createList) > 0 { - changeList2Yb(createList, nil) + changeList2Yb(createList, nil, storeDetail.YbStorePrefix) } } task := tasksch.NewParallelTask("syncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError2), ctx, @@ -1271,3 +1255,20 @@ func FullSyncStoreSkuBindAct(ctx *jxcontext.Context, parentTask tasksch.ITask, h _, err = task.GetResult(0) return err } + +func changeList2Yb(list1 []*dao.StoreSkuSyncInfo, list2 []*partner.StoreSkuInfo, ybStorePrefix string) { + var ( + skuNameMap = make(map[int]*dao.StoreSkuSyncInfo) + ) + for _, v := range list1 { + skuNameMap[v.NameID] = v + } + list1 = list1[0:0] + for _, v := range skuNameMap { + list1 = append(list1, v) + } + for _, v := range list1 { + v.YbBarCode = ybStorePrefix + v.YbNameSuffix + } + fmt.Println(utils.Format4Output(list1, false)) +}