fix

app/service/supplier_sku_mode.go

@@ -17,7 +17,7 @@ func SaveSkuModeFromES() (err error) {
 	supplier := new(model.Supplier)
 	supplier := new(model.Supplier)
 	//先去根据供应商内部编码找出对应的supplierId
 	//先去根据供应商内部编码找出对应的supplierId
 	rows, err := dao.Dao.GetDb("supplier").Table("lie_supplier_channel").
 	rows, err := dao.Dao.GetDb("supplier").Table("lie_supplier_channel").
-		// Where("supplier_code = ?", "L0001175").
+		// Where("supplier_code = ?", "L0012486").
 		Where("is_type = ?", 0).
 		Where("is_type = ?", 0).
 		Where("uploaded_sku = ?", 1).
 		Where("uploaded_sku = ?", 1).
 		OrderBy("supplier_id desc").
 		OrderBy("supplier_id desc").
@@ -34,7 +34,7 @@ func SaveSkuModeFromES() (err error) {
 		params := req.Param{
 		params := req.Param{
 			"canal/condition": supplier.SupplierCode,
 			"canal/condition": supplier.SupplierCode,
 			"cp_time/sort":    "asc",
 			"cp_time/sort":    "asc",
-			"cp_time/neq":     0,
+			"cp_time/no_eqs":  0,
 		}
 		}
 		url := lib.Instance("config").GetString("es.es_sku_url")
 		url := lib.Instance("config").GetString("es.es_sku_url")
 		resp, err := req.Post(url, params)
 		resp, err := req.Post(url, params)
@@ -43,11 +43,12 @@ func SaveSkuModeFromES() (err error) {
 		}
 		}
 		result := resp.String()
 		result := resp.String()
 		goodsIdArr := gjson.Get(result, "data.goods_id").Array()
 		goodsIdArr := gjson.Get(result, "data.goods_id").Array()
+		// fmt.Println(goodsIdArr)
 		// fmt.Println("当前处理供应商为 : ", supplier.SupplierName)
 		// fmt.Println("当前处理供应商为 : ", supplier.SupplierName)
 		if len(goodsIdArr) > 0 {
 		if len(goodsIdArr) > 0 {
 			//取一个goods_id就好
 			//取一个goods_id就好
 			goodsId := goodsIdArr[0].String()
 			goodsId := goodsIdArr[0].String()
-			//fmt.Println("skuId为 : " + goodsId)
+			fmt.Println("skuId为 : " + goodsId)
 			//去redis里面找出对应的goods_label
 			//去redis里面找出对应的goods_label
 			redisCon := dao.Dao.GetRedisDbGroup("sku")
 			redisCon := dao.Dao.GetRedisDbGroup("sku")
 			result := redisCon.HGet("goods_tag", goodsId).String()
 			result := redisCon.HGet("goods_tag", goodsId).String()
@@ -71,6 +72,7 @@ func SaveSkuModeFromES() (err error) {
 			sku := redisCon.HGet("sku", goodsId).String()
 			sku := redisCon.HGet("sku", goodsId).String()
 			skuExpiredInDays := 0
 			skuExpiredInDays := 0
 			cpTime := gjson.Get(sku, "cp_time").Int()
 			cpTime := gjson.Get(sku, "cp_time").Int()
+			fmt.Println(cpTime)
 			if cpTime > 0 {
 			if cpTime > 0 {
 				//cp_time是时间戳,转成日期和当前日期对比计算天数
 				//cp_time是时间戳,转成日期和当前日期对比计算天数
 				cpTimeDate := time.Unix(cpTime, 0)
 				cpTimeDate := time.Unix(cpTime, 0)

config/dev/config.toml

@@ -2,4 +2,5 @@
    url = "amqp://guest:guest@192.168.1.252:5672/"
    url = "amqp://guest:guest@192.168.1.252:5672/"
 
 
 [es]
 [es]
-  es_sku_url = "https://icso.ichunt.com/search/es/searchSku"
+ # es_sku_url = "https://icso.ichunt.com/search/es/searchSku"
\ No newline at end of file
+  es_sku_url = "http://search.liexindev.net/search/es/searchSku"
\ No newline at end of file