京东商城一系列

business/jxstore/cms/sync_store_sku.go

@@ -460,6 +460,8 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
 				if sku.MergedStatus == model.SkuStatusNormal {
 					if dao.IsVendorThingIDEmpty(sku.VendorCatID) && !strings.Contains(sku.StoreName, model.ExdStoreName) && vendorID != model.VendorIDYB && vendorID != model.VendorIDJDShop {
 						globals.SugarLogger.Warnf("syncStoreSkuNew 创建门店:%d商品:%d，但没有平台分类ID", storeID, sku.SkuID)
+					} else if dao.IsVendorThingIDEmpty(utils.Int64ToStr(sku.VendorVendorCatID)) && vendorID == model.VendorIDJDShop {
+						globals.SugarLogger.Warnf("syncStoreSkuNew 创建门店:%d商品:%d，但没有映射的平台ID", storeID, sku.SkuID)
 					} else {
 						createList = append(createList, sku)
 					}

business/partner/purchase/jdshop/store_sku.go

@@ -25,7 +25,10 @@ var (
 
 func (p *PurchaseHandler) CreateStoreSkus(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeSkuList []*dao.StoreSkuSyncInfo) (failedList []*partner.StoreSkuInfoWithErr, err error) {
 	if globals.EnableJdShopWrite && vendorStoreID == model.JdShopMainVendorStoreID {
-
+		for _, v := range storeSkuList {
+			buildCreateWareParam(v)
+			// api.JdShopAPI.CreateWare(createSkuParamWare, createSkuParamSkus)
+		}
 	}
 	return failedList, err
 }
@@ -264,3 +267,40 @@ func updateOrCreateCategories(storeCat *dao.SkuStoreCatInfo, isCreate bool) (err
 	err = api.JdShopAPI.CreateShopCategory(createShopCategoryParams)
 	return err
 }
+
+func buildCreateWareParam(storeSku *dao.StoreSkuSyncInfo) (createSkuParamWare *jdshopapi.CreateSkuParamWare, createSkuParamSkus []*jdshopapi.CreateSkuParamSkus, err error) {
+	var images []*jdshopapi.CreateSkuParamImages
+	createSkuParamWare = &jdshopapi.CreateSkuParamWare{
+		Title:         storeSku.SkuName,
+		ShopCategorys: []int{utils.Str2Int(storeSku.VendorCatID)},
+		CategoryID:    int(storeSku.VendorVendorCatID),
+		BrandID:       jdshopapi.JxBrandId,
+		TransportID:   jdshopapi.TransportID,
+		MobileDesc:    " ",
+		Introduction:  " ",
+		WareStatus:    8, //上架待审核
+		OuterID:       utils.Int2Str(storeSku.SkuID),
+		VenderID:      0,
+		Is7ToReturn:   0, //不支持7天退货
+		Length:        100,
+		Width:         100,
+		Height:        100,
+		Weight:        storeSku.Weight,
+		JdPrice:       int(storeSku.VendorPrice),
+		MarketPrice:   int(storeSku.Price),
+	}
+	data, _, err := jxutils.DownloadFileByURL(storeSku.Img)
+	if err != nil {
+		return createSkuParamWare, createSkuParamSkus, err
+	}
+	api.JdShopAPI.UploadPicture(data, 0, storeSku.Name)
+	for i := 1; i < 3; i++ {
+		img := &jdshopapi.CreateSkuParamImages{
+			ColorID:  "0000000000",
+			ImgIndex: i,
+			ImgURL:   "",
+		}
+		images = append(images, img)
+	}
+	return createSkuParamWare, createSkuParamSkus, err
+}