From 3f35f2bc96405e1f742722a4f4167aad9d3cb28d Mon Sep 17 00:00:00 2001 From: TsMask <340112800@qq.com> Date: Wed, 6 Sep 2023 10:46:50 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8F=82=E6=95=B0=E9=85=8D=E7=BD=AE=E6=8F=92?= =?UTF-8?q?=E5=85=A5=E7=BB=93=E6=9E=9C=E8=BF=94=E5=9B=9E=E8=AE=B0=E5=BD=95?= =?UTF-8?q?ID?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sys_config/service/repo_sys_config.go | 25 +++++++++++++++---- 1 file changed, 20 insertions(+), 5 deletions(-) diff --git a/features/sys_config/service/repo_sys_config.go b/features/sys_config/service/repo_sys_config.go index 95c4cb1f..488d7c9a 100644 --- a/features/sys_config/service/repo_sys_config.go +++ b/features/sys_config/service/repo_sys_config.go @@ -260,13 +260,18 @@ func (r *RepoSysConfig) InsertConfig(sysConfig model.SysConfig) string { sql := "insert into sys_config (" + strings.Join(keys, ",") + ")values(" + placeholder + ")" // 执行插入 - rows, err := datasource.ExecDB("", sql, values) + results, err := datasource.ExecDB("", sql, values) if err != nil { log.Errorf("insert row : %v", err.Error()) return "" } - return fmt.Sprint(rows) + insertId, err := results.LastInsertId() + if err != nil { + log.Errorf("insert row : %v", err.Error()) + return "" + } + return fmt.Sprint(insertId) } // UpdateConfig 修改参数配置 @@ -299,12 +304,17 @@ func (r *RepoSysConfig) UpdateConfig(sysConfig model.SysConfig) int64 { // 执行更新 values = append(values, sysConfig.ConfigID) - rows, err := datasource.ExecDB("", sql, values) + results, err := datasource.ExecDB("", sql, values) if err != nil { log.Errorf("update row : %v", err.Error()) return 0 } - return rows + affected, err := results.RowsAffected() + if err != nil { + log.Errorf("update err => %v", err) + return 0 + } + return affected } // DeleteConfigByIds 批量删除参数配置信息 @@ -317,5 +327,10 @@ func (r *RepoSysConfig) DeleteConfigByIds(configIds []string) int64 { log.Errorf("delete err => %v", err) return 0 } - return results + affected, err := results.RowsAffected() + if err != nil { + log.Errorf("delete err => %v", err) + return 0 + } + return affected }