fix

app/dao/supplier.go

@@ -40,7 +40,7 @@ func StatisticsSuppliersSkuNum() (err error) {
 			return err
 			return err
 		}
 		}
 	}
 	}
-	fmt.Println("执行完成,有上传sku的供应商数量为 : ",num)
+	fmt.Println("执行完成,有上传sku的供应商数量为 : ", num)
 	return
 	return
 }
 }
 
 
@@ -57,7 +57,7 @@ func UpdateSupplierSkuNum(supplierId, skuNum int) (err error) {
 	}
 	}
 	supplier.SkuNum = skuNum
 	supplier.SkuNum = skuNum
 	//还要去写映射表lie_supplier_merger_mapping
 	//还要去写映射表lie_supplier_merger_mapping
-	_, err = Dao.GetDb("supplier").Table("lie_supplier_channel").Where("supplier_id = ?", supplierId).Update(supplier)
+	_, err = Dao.GetDb("supplier").Table("lie_supplier_channel").Where("supplier_id = ?", supplierId).Cols("sku_num").Update(supplier)
 	if err != nil {
 	if err != nil {
 		return err
 		return err
 	}
 	}
@@ -77,7 +77,7 @@ func UpdateSupplierSkuMode(supplierId, skuMode int) (err error) {
 	}
 	}
 	supplier.SkuMode = skuMode
 	supplier.SkuMode = skuMode
 	//还要去写映射表lie_supplier_merger_mapping
 	//还要去写映射表lie_supplier_merger_mapping
-	_, err = Dao.GetDb("supplier").Table("lie_supplier_channel").Where("supplier_id = ?", supplierId).Update(supplier)
+	_, err = Dao.GetDb("supplier").Table("lie_supplier_channel").Cols("sku_mode").Where("supplier_id = ?", supplierId).Update(supplier)
 	if err != nil {
 	if err != nil {
 		return err
 		return err
 	}
 	}

app/service/supplier_sku_mode.go

@@ -50,6 +50,10 @@ func SaveSkuModeFromES() (err error) {
 				}
 				}
 			}
 			}
 		}
 		}
+		err = dao.UpdateSupplierSkuMode(supplier.SupplierId, 0)
+		if err != nil {
+			return err
+		}
 		time.Sleep(100 * time.Millisecond)
 		time.Sleep(100 * time.Millisecond)
 	}
 	}
 	fmt.Println("执行完成")
 	fmt.Println("执行完成")