From 2c2645d4b24838fcdd716ec482032469ea623c40 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Thu, 7 Jan 2021 11:34:40 +0800
Subject: [PATCH] aa

---
 business/model/dao/store_sku.go              | 19 +++++
 business/partner/purchase/ebai/store_sku2.go | 86 +++++++++++++++++++-
 2 files changed, 101 insertions(+), 4 deletions(-)

diff --git a/business/model/dao/store_sku.go b/business/model/dao/store_sku.go
index 167242787..b37713100 100644
--- a/business/model/dao/store_sku.go
+++ b/business/model/dao/store_sku.go
@@ -1746,3 +1746,22 @@ func GetStoreSkuHistory(db *DaoDB, storeIDs, skuIDs []int, status int, snapShot
 	err = GetRows(db, &storeSkuHistory, sql, sqlParams...)
 	return storeSkuHistory, err
 }
+
+func GetStoreSkuCategoryMap(db *DaoDB, categoryID, storeID int) (storeSkuCategoryMap *model.StoreSkuCategoryMap, err error) {
+	sql := `
+		SELECT *
+		  FROM store_sku_category_map
+		 WHERE deleted_at = ? 
+	`
+	sqlParams := []interface{}{utils.DefaultTimeValue}
+	if categoryID != 0 {
+		sql += " AND category_id = ? "
+		sqlParams = append(sqlParams, categoryID)
+	}
+	if storeID != 0 {
+		sql += " AND store_id = ? "
+		sqlParams = append(sqlParams, storeID)
+	}
+	GetRow(db, &storeSkuCategoryMap, sql, sqlParams)
+	return storeSkuCategoryMap, err
+}
diff --git a/business/partner/purchase/ebai/store_sku2.go b/business/partner/purchase/ebai/store_sku2.go
index 376bb295b..654900072 100644
--- a/business/partner/purchase/ebai/store_sku2.go
+++ b/business/partner/purchase/ebai/store_sku2.go
@@ -36,6 +36,66 @@ var (
 		201223525: 1,
 		201220334: 1,
 	}
+
+	ebaiExSkuCatMap2 = map[int]int{
+		6046399: 1,
+		6046283: 1,
+		23001:   1,
+		30768:   1,
+		24037:   1,
+		24838:   1,
+		35052:   1,
+		30859:   1,
+		28490:   1,
+		6040798: 1,
+		6046267: 1,
+		31029:   1,
+		35508:   1,
+		33727:   1,
+	}
+
+	ebaiExSkuCatMap = map[int]int{
+		32576:   1,
+		22856:   1,
+		35231:   1,
+		30593:   1,
+		6045151: 1,
+		6046299: 1,
+		31237:   1,
+		28854:   1,
+		29605:   1,
+		26330:   1,
+		6045121: 1,
+		6045448: 1,
+		30629:   1,
+		6045163: 1,
+		30876:   1,
+		6041954: 1,
+		23814:   1,
+		6045621: 1,
+		33298:   1,
+		27136:   1,
+		6043711: 1,
+		30822:   1,
+		25019:   1,
+		30704:   1,
+		30644:   1,
+		23868:   1,
+		26049:   1,
+		30635:   1,
+		6045955: 1,
+		30672:   1,
+		30641:   1,
+		6045863: 1,
+		30781:   1,
+		6046413: 1,
+		30686:   1,
+		34417:   1,
+		30611:   1,
+		23065:   1,
+		30676:   1,
+		30706:   1,
+	}
 )
 
 func (p *PurchaseHandler) GetStoreSkusBatchSize(funcID int) (batchSize int) {
@@ -330,9 +390,6 @@ func genSkuParamsFromStoreSkuInfo2(storeSku *dao.StoreSkuSyncInfo, isCreate, isE
 	} else {
 		img = storeSku.Img
 	}
-	if storeSku.NameID == 8024827 {
-		img = storeSku.ImgOrigin
-	}
 	photos := []map[string]interface{}{
 		map[string]interface{}{
 			"is_master": true,
@@ -362,7 +419,28 @@ func genSkuParamsFromStoreSkuInfo2(storeSku *dao.StoreSkuSyncInfo, isCreate, isE
 		"preparation_time": storeSku.PreparationTime,
 	}
 	if !isExd {
-		params["category_id"] = utils.Str2Int64(storeSku.VendorCatID)
+		if ebaiExSkuCatMap[storeSku.SkuID] != 0 {
+			store, _ := dao.GetStoreDetail(dao.GetDB(), storeSku.StoreID, model.VendorIDEBAI, "")
+			if store.CityCode == 510100 {
+				s, _ := dao.GetStoreSkuCategoryMap(dao.GetDB(), 439, storeSku.StoreID)
+				params["category_id"] = s.EbaiID
+			} else {
+				params["category_id"] = utils.Str2Int64(storeSku.VendorCatID)
+			}
+		} else {
+			params["category_id"] = utils.Str2Int64(storeSku.VendorCatID)
+		}
+		if ebaiExSkuCatMap2[storeSku.SkuID] != 0 {
+			store, _ := dao.GetStoreDetail(dao.GetDB(), storeSku.StoreID, model.VendorIDEBAI, "")
+			if store.CityCode == 510100 {
+				s, _ := dao.GetStoreSkuCategoryMap(dao.GetDB(), 440, storeSku.StoreID)
+				params["category_id"] = s.EbaiID
+			} else {
+				params["category_id"] = utils.Str2Int64(storeSku.VendorCatID)
+			}
+		} else {
+			params["category_id"] = utils.Str2Int64(storeSku.VendorCatID)
+		}
 		params["name"] = utils.LimitMixedStringLen(storeSku.SkuName, ebaiapi.MaxSkuNameByteCount)
 		params["cat3_id"] = getEbaiCat(storeSku.VendorVendorCatID)
 	} else {