From 8ea14dd10b23d8d675ea8328ec0f8a0364543619 Mon Sep 17 00:00:00 2001 From: wubin Date: Thu, 6 Aug 2020 10:09:27 +0800 Subject: [PATCH] update --- dsBaseRpc/Config/Config.ini | 4 ++-- dsBaseRpc/Utils/SqlKit/SqlKit.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/dsBaseRpc/Config/Config.ini b/dsBaseRpc/Config/Config.ini index 62bd776f..8f691fbf 100644 --- a/dsBaseRpc/Config/Config.ini +++ b/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] diff --git a/dsBaseRpc/Utils/SqlKit/SqlKit.go b/dsBaseRpc/Utils/SqlKit/SqlKit.go index 38e2b354..c6d23092 100644 --- a/dsBaseRpc/Utils/SqlKit/SqlKit.go +++ b/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