Commit 46624b0e by 杨树贤

优化脚本

parent 6cd9a63a
Showing with 1 additions and 3 deletions
...@@ -45,7 +45,6 @@ func SaveSkuModeFromES() (err error) { ...@@ -45,7 +45,6 @@ func SaveSkuModeFromES() (err error) {
goodsIdArr := gjson.Get(result, "data.goods_id").Array() goodsIdArr := gjson.Get(result, "data.goods_id").Array()
// fmt.Println("当前处理供应商为 : ", supplier.SupplierName) // fmt.Println("当前处理供应商为 : ", supplier.SupplierName)
if len(goodsIdArr) > 0 { if len(goodsIdArr) > 0 {
fmt.Println("存在商品")
//取一个goods_id就好 //取一个goods_id就好
goodsId := goodsIdArr[0].String() goodsId := goodsIdArr[0].String()
//fmt.Println("skuId为 : " + goodsId) //fmt.Println("skuId为 : " + goodsId)
...@@ -72,7 +71,6 @@ func SaveSkuModeFromES() (err error) { ...@@ -72,7 +71,6 @@ 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:", cpTime)
if cpTime > 0 { if cpTime > 0 {
//cp_time是时间戳,转成日期和当前日期对比计算天数 //cp_time是时间戳,转成日期和当前日期对比计算天数
cpTimeDate := time.Unix(cpTime, 0) cpTimeDate := time.Unix(cpTime, 0)
...@@ -87,7 +85,7 @@ func SaveSkuModeFromES() (err error) { ...@@ -87,7 +85,7 @@ func SaveSkuModeFromES() (err error) {
} }
} }
if skuExpiredInDays > 0 { if skuExpiredInDays > 0 {
fmt.Println("sku过期天数 : ", skuExpiredInDays) fmt.Println("sku过期天数 : ", skuExpiredInDays, "供应商编码 : ", supplier.SupplierCode)
} }
err = dao.UpdateSupplierSkuExpiredInDays(supplier.SupplierId, skuExpiredInDays) err = dao.UpdateSupplierSkuExpiredInDays(supplier.SupplierId, skuExpiredInDays)
if err != nil { if err != nil {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment