修改时间

app/service/supplier_sku_mode.go

@@ -7,7 +7,6 @@ import (
 	"github.com/tidwall/gjson"
 	"github.com/tidwall/gjson"
 	"go_supplier_sever/app/dao"
 	"go_supplier_sever/app/dao"
 	"go_supplier_sever/app/model"
 	"go_supplier_sever/app/model"
-	"time"
 )
 )
 
 
 //从ES统计出sku类型,然后写到供应商的sku_mode字段
 //从ES统计出sku类型,然后写到供应商的sku_mode字段
@@ -19,6 +18,7 @@ func SaveSkuModeFromES() (err error) {
 		return err
 		return err
 	}
 	}
 	defer rows.Close()
 	defer rows.Close()
+	var num int
 	for rows.Next() {
 	for rows.Next() {
 		err = rows.Scan(supplier)
 		err = rows.Scan(supplier)
 		//去es查询sku数量
 		//去es查询sku数量
@@ -48,14 +48,15 @@ func SaveSkuModeFromES() (err error) {
 				if err != nil {
 				if err != nil {
 					return err
 					return err
 				}
 				}
+				num++
 			}
 			}
 		}
 		}
 		err = dao.UpdateSupplierSkuMode(supplier.SupplierId, 0)
 		err = dao.UpdateSupplierSkuMode(supplier.SupplierId, 0)
 		if err != nil {
 		if err != nil {
 			return err
 			return err
 		}
 		}
-		time.Sleep(100 * time.Millisecond)
+		//time.Sleep(100 * time.Millisecond)
 	}
 	}
-	fmt.Println("执行完成")
+	fmt.Println("执行完成,有sku_mode的供应商数量为 : ", num)
 	return
 	return
 }
 }