尝试银豹skuname上

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))
+}