修复统计问题

app/dao/supplier.go

@@ -77,7 +77,7 @@ func StatisticsSuppliersSkuNum() (err error) {
 			}
 			if updateSkuTime > 0 {
 				supplier.SkuUpdateTime = updateSkuTime
-				affected, err := Dao.GetDb("supplier").Table("lie_supplier_channel").Where("supplier_id = ?", supplier.SupplierId).MustCols("sku_update_time").Update(supplier)
+				affected, err := Dao.GetDb("supplier").Table("lie_supplier_channel").Where("supplier_id = ?", supplier.SupplierId).Cols("sku_update_time").Update(supplier)
 				if affected > 0 {
 				}
 				if err != nil {
@@ -137,8 +137,9 @@ func StatisticsSuppliersHasUploadedSku() (err error) {
 
 func UpdateSupplierSkuNum(supplierId, skuNum int) (err error) {
 	supplier := new(model.Supplier)
+	db:=Dao.GetDb("supplier")
 	//先去根据供应商内部编码找出对应的supplierId
-	_, err = Dao.GetDb("supplier").Table("lie_supplier_channel").Where("supplier_id = ?", supplierId).Get(supplier)
+	_, err = db.Table("lie_supplier_channel").Where("supplier_id = ?", supplierId).Get(supplier)
 	if supplier.SupplierId == 0 {
 		return err
 	}
@@ -146,20 +147,18 @@ func UpdateSupplierSkuNum(supplierId, skuNum int) (err error) {
 		return err
 	}
 	supplier.SkuNum = skuNum
-	//还要去写映射表lie_supplier_merger_mapping
-	_, err = Dao.GetDb("supplier").Table("lie_supplier_channel").Where("supplier_id = ?", supplierId).Cols("sku_num").Update(supplier)
-	if err != nil {
-		return err
-	}
-
 	//去修改历史上传过SKU的标志
 	if supplier.UploadedSku == -1 && skuNum > 0 {
+		//supplier.SkuNum = 1000
 		fmt.Println("新增历史上传SKU供应商 : " + supplier.SupplierName)
 		supplier.UploadedSku = 1
-		_, err = Dao.GetDb("supplier").Table("lie_supplier_channel").Where("supplier_id = ?", supplierId).MustCols("uploaded_sku").Update(supplier)
-		if err != nil {
-			return err
-		}
+	}
+	_, err = db.Table("lie_supplier_channel").Where("supplier_id = ?", supplierId).Cols("sku_num","uploaded_sku").Update(supplier)
+	//if skuNum > 0 {
+	//	db.ShowSQL()
+	//}
+	if err != nil {
+		return err
 	}
 	return
 }