修改统计逻辑

app/dao/supplier.go

@@ -137,7 +137,7 @@ func StatisticsSuppliersHasUploadedSku() (err error) {
 
 func UpdateSupplierSkuNum(supplierId, skuNum int) (err error) {
 	supplier := new(model.Supplier)
-	db:=Dao.GetDb("supplier")
+	db := Dao.GetDb("supplier")
 	//先去根据供应商内部编码找出对应的supplierId
 	_, err = db.Table("lie_supplier_channel").Where("supplier_id = ?", supplierId).Get(supplier)
 	if supplier.SupplierId == 0 {
@@ -153,7 +153,7 @@ func UpdateSupplierSkuNum(supplierId, skuNum int) (err error) {
 		fmt.Println("新增历史上传SKU供应商 : " + supplier.SupplierName)
 		supplier.UploadedSku = 1
 	}
-	_, err = db.Table("lie_supplier_channel").Where("supplier_id = ?", supplierId).Cols("sku_num","uploaded_sku").Update(supplier)
+	_, err = db.Table("lie_supplier_channel").Where("supplier_id = ?", supplierId).Cols("sku_num", "uploaded_sku").Update(supplier)
 	//if skuNum > 0 {
 	//	db.ShowSQL()
 	//}
@@ -285,7 +285,7 @@ func StatisticsSkuCreateTime() (err error) {
 	supplier := new(model.Supplier)
 	//先去根据供应商内部编码找出对应的supplierId
 	rows, err := Dao.GetDb("supplier").Table("lie_supplier_channel").
-		Where("sku_create_time = ?", 0).Where("uploaded_sku = ?", 1).
+		Where("sku_create_time = ?", 0).
 		Where("is_type = ?", 0).OrderBy("supplier_id desc").Rows(supplier)
 	if err != nil {
 		return err
@@ -319,6 +319,7 @@ func StatisticsSkuCreateTime() (err error) {
 		}
 		if skuCreateTime > 0 {
 			supplier.SkuCreateTime = skuCreateTime
+			supplier.UploadedSku = 1
 			affected, err := Dao.GetDb("supplier").Table("lie_supplier_channel").Where("supplier_id = ?", supplier.SupplierId).MustCols("sku_create_time").Update(supplier)
 			if affected > 0 {
 			}