修改统计

app/dao/supplier.go

@@ -66,6 +66,11 @@ func StatisticsSuppliersSkuNum() (err error) {
 		sku更新时间
 		**/
 		if skuNum > 0 {
+			//修改历史上传sku
+			err = UpdateSupplierHasUploadedSku(supplier.SupplierId, 1)
+			if err != nil {
+				return err
+			}
 			updateSkuTime := 0
 			//找到第一个sku_id的更新时间
 			updateTimeMap := gjson.Get(result, "data.update_time").Map()
@@ -156,7 +161,7 @@ func UpdateSupplierSkuNum(supplierId, skuNum int) (err error) {
 	if supplier.UploadedSku == -1 && skuNum > 0 {
 		fmt.Println("新增历史上传SKU供应商 : " + supplier.SupplierName)
 		supplier.UploadedSku = 1
-		_, err = Dao.GetDb("supplier").Table("lie_supplier_channel").Where("supplier_id = ?", supplierId).Cols("uploaded_sku").Update(supplier)
+		_, err = Dao.GetDb("supplier").Table("lie_supplier_channel").Where("supplier_id = ?", supplierId).MustCols("uploaded_sku").Update(supplier)
 		if err != nil {
 			return err
 		}