1.0

service/common_ly_service.go

@@ -20,6 +20,13 @@ var supplier_over_time = map[string]int64{
 	"buerklin":3600,
 }
 
+//调用当前方法的供应商名称
+var supplier_name string="";
+
+//组装批量更新es数据
+var sku_list []map[string]interface{}
+
+//redis 相关
 var sku_uique_judge string = config.Get("redis_all.SKU_UNIQUE_JUDGE").String()  //sku唯一键
 var spu_uique_judge string = config.Get("redis_all.SPU_UNIQUE_JUDGE").String()  //spu唯一键
 var brand_name_all string = config.Get("redis_all.BRAND_NAME_ALL").String()    //品牌键
@@ -37,7 +44,7 @@ func getSkuByGoodsSn(goods_list map[string]*model.LyClearGoodsList,supplier_info
 	for goods_sn, info := range goods_list {
 
 		sn_sku := php2go.Md5(strings.ToLower(goods_sn))
-		sku_id,_ := gredis.HGet(sku_uique_judge,sn_sku) //查询唯一值，反查sku_id
+		sku_id,_ := gredis.hget(sku_uique_judge,sn_sku) //查询唯一值，反查sku_id
 
 		var sku_flag bool = false; //是否新增或者更新db+redis,为true则新增
 		if sku_id == "" { //为空，先创建sku
@@ -131,6 +138,12 @@ func writeBrandInfo(sku_info *model.LyClearGoodsList)  {
 		UpdateTime:,
 	}
 }
+/*
+组装推送到es数据
+ */
+func esSkuInfo(sku_info *model.LyClearGoodsList)  {
+
+}
 
 /*
 推入队列