update

dsBaseRpc/Config/Config.ini

@@ -6,7 +6,7 @@ user = root
 pwd = DsideaL147258369
 
 [distribute]    #发布功能的配置
-ip = server.dsmin.com
+ip = 10.10.14.187
 port = 22
 user = root
 pwd = dsideal
@@ -28,7 +28,7 @@ port = 8001
 project_name = dsBaseRpc
 
 [kafka]
-KafkaAddress = server.dsmin.com:9092
+KafkaAddress = 10.10.14.187:9092
 
 # 数据汇集的地址
 [dataExchange]

dsBaseRpc/Utils/SqlKit/SqlKit.go

@@ -33,7 +33,7 @@ func DeleteIds(tableName string, ids []string) error {
 	_, PkField := GetTablePk(tableName)
 	//3、批量删除
 	// -1:未启用，-2：删除
-	var myBuilder = builder.Dialect(builder.MYSQL).Update(builder.Eq{"b_use": -2}).From(tableName).Where(builder.In(PkField, ids))
+	var myBuilder = builder.Dialect(builder.MYSQL).Delete().From(tableName).Where(builder.In(PkField, ids))
 	sql, _ := myBuilder.ToBoundSQL()
 	_, err := db.SQL(sql).Execute()
 	return err