From 3301ee8536c642c893957127f8e900d5d5f339f8 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Wed, 15 Apr 2020 16:53:04 +0800
Subject: [PATCH] =?UTF-8?q?=E6=A0=87=E5=93=81=E6=9F=A5=E8=AF=A2=E5=AD=98?=
 =?UTF-8?q?=E5=88=B0=E5=BA=93=E9=87=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 business/jxstore/cms/sku.go | 11 ++++++++++-
 business/model/dao/sku.go   | 32 ++++++++++++++++++++++++++++++++
 2 files changed, 42 insertions(+), 1 deletion(-)

diff --git a/business/jxstore/cms/sku.go b/business/jxstore/cms/sku.go
index 61b015c88..f10ad79e2 100644
--- a/business/jxstore/cms/sku.go
+++ b/business/jxstore/cms/sku.go
@@ -11,6 +11,8 @@ import (
 	"strings"
 	"time"
 
+	"git.rosy.net.cn/baseapi/platformapi/aliupcapi"
+
 	"git.rosy.net.cn/baseapi"
 	"git.rosy.net.cn/baseapi/platformapi/dingdingapi"
 	"git.rosy.net.cn/baseapi/platformapi/ebaiapi"
@@ -1882,7 +1884,14 @@ func CreateUpcSkuByExcelBin(ctx *jxcontext.Context, reader io.Reader, categoryID
 					return retVal, err
 				}
 				if len(productInfos) == 0 {
-					result, _ := api.AliUpcAPI.GetAliUpcInfo(*v.Upc)
+					var result *aliupcapi.GetAliUpcInfoResult
+					upcDepot, err := dao.GetUpcDepot(db, *v.Upc)
+					if upcDepot == nil {
+						result, _ = api.AliUpcAPI.GetAliUpcInfo(*v.Upc)
+						err = dao.InsertUpcDepot(db, result)
+					} else {
+						result = upcDepot
+					}
 					if result == nil {
 						retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, "未在标品库查到此商品，请手动创建！")}
 						return retVal, err
diff --git a/business/model/dao/sku.go b/business/model/dao/sku.go
index 206417257..0c9e65c3d 100644
--- a/business/model/dao/sku.go
+++ b/business/model/dao/sku.go
@@ -1,6 +1,7 @@
 package dao
 
 import (
+	"git.rosy.net.cn/baseapi/platformapi/aliupcapi"
 	"git.rosy.net.cn/baseapi/utils"
 	"git.rosy.net.cn/jx-callback/business/model"
 )
@@ -342,3 +343,34 @@ func GetSkuNamePlaces(db *DaoDB, nameIDs, skuIDs []int) (skuPlaceList []*SkuName
 	err = GetRows(db, &skuPlaceList, sql, sqlParams...)
 	return skuPlaceList, err
 }
+
+func GetUpcDepot(db *DaoDB, upc string) (result *aliupcapi.GetAliUpcInfoResult, err error) {
+	sql := `
+		SELECT * FROM upc_depot WHERE code = ?
+	`
+	sqlParams := []interface{}{upc}
+	err = GetRows(db, &result, sql, sqlParams...)
+	return result, err
+}
+
+func InsertUpcDepot(db *DaoDB, result *aliupcapi.GetAliUpcInfoResult) (err error) {
+	sql := `
+		INSERT INTO upc_depot (code, goods_name, manu_name, manu_address, spec, price, img, goods_type, ycg, trade_mark, remark)
+		VALUES ?,?,?,?,?,?,?,?,?,?,?
+	`
+	sqlParams := []interface{}{
+		result.Code,
+		result.GoodsName,
+		result.ManuName,
+		result.ManuAddress,
+		result.Spec,
+		result.Price,
+		result.Img,
+		result.GoodsType,
+		result.Ycg,
+		result.Trademark,
+		result.Remark,
+	}
+	_, err = ExecuteSQL(db, sql, sqlParams)
+	return err
+}