mirror of
https://github.com/go-admin-team/go-admin.git
synced 2026-09-21 02:04:09 +00:00
fix🐛 query built from **** sources
This commit is contained in:
@@ -2,6 +2,7 @@ package service
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
"errors"
|
||||||
|
common "go-admin/common/models"
|
||||||
|
|
||||||
"gorm.io/gorm"
|
"gorm.io/gorm"
|
||||||
|
|
||||||
@@ -71,10 +72,13 @@ func (e *SysChinaAreaData) InsertSysChinaAreaData(model *models.SysChinaAreaData
|
|||||||
|
|
||||||
// UpdateSysChinaAreaData 修改SysChinaAreaData对象
|
// UpdateSysChinaAreaData 修改SysChinaAreaData对象
|
||||||
func (e *SysChinaAreaData) UpdateSysChinaAreaData(c *models.SysChinaAreaData, p *actions.DataPermission) error {
|
func (e *SysChinaAreaData) UpdateSysChinaAreaData(c *models.SysChinaAreaData, p *actions.DataPermission) error {
|
||||||
db := e.Orm.Model(c).
|
db := e.Orm.Model(&models.SysChinaAreaData{
|
||||||
|
Model: common.Model{
|
||||||
|
Id: c.GetId().(int),
|
||||||
|
}}).
|
||||||
Scopes(
|
Scopes(
|
||||||
actions.Permission(c.TableName(), p),
|
actions.Permission(c.TableName(), p),
|
||||||
).Where(c.GetId()).Updates(c)
|
).Updates(c)
|
||||||
if err := db.Error; err != nil {
|
if err := db.Error; err != nil {
|
||||||
e.Log.Errorf("Service UpdateSysChinaAreaData error: %s", err)
|
e.Log.Errorf("Service UpdateSysChinaAreaData error: %s", err)
|
||||||
return err
|
return err
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import (
|
|||||||
"go-admin/app/admin/models/system"
|
"go-admin/app/admin/models/system"
|
||||||
"go-admin/app/admin/service/dto"
|
"go-admin/app/admin/service/dto"
|
||||||
cDto "go-admin/common/dto"
|
cDto "go-admin/common/dto"
|
||||||
|
common "go-admin/common/models"
|
||||||
"go-admin/common/service"
|
"go-admin/common/service"
|
||||||
"gorm.io/gorm"
|
"gorm.io/gorm"
|
||||||
)
|
)
|
||||||
@@ -84,8 +85,9 @@ func (e *SysConfig) InsertSysConfig(model *system.SysConfig) error {
|
|||||||
func (e *SysConfig) UpdateSysConfig(c *system.SysConfig) error {
|
func (e *SysConfig) UpdateSysConfig(c *system.SysConfig) error {
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
db := e.Orm.Model(c).
|
db := e.Orm.Model(&system.SysConfig{Model: common.Model{
|
||||||
Where(c.GetId()).Updates(c)
|
Id: c.GetId().(int),
|
||||||
|
}}).Updates(c)
|
||||||
err = db.Error
|
err = db.Error
|
||||||
if err != nil {
|
if err != nil {
|
||||||
e.Log.Errorf("Service UpdateSysConfig error:%s", err)
|
e.Log.Errorf("Service UpdateSysConfig error:%s", err)
|
||||||
@@ -103,8 +105,7 @@ func (e *SysConfig) RemoveSysConfig(d *dto.SysConfigById, c *system.SysConfig) e
|
|||||||
var err error
|
var err error
|
||||||
var data system.SysConfig
|
var data system.SysConfig
|
||||||
|
|
||||||
db := e.Orm.Model(&data).
|
db := e.Orm.Model(&data).Delete(c, d.Ids)
|
||||||
Where(d.Ids).Delete(c)
|
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
err = db.Error
|
err = db.Error
|
||||||
e.Log.Errorf("Service RemoveSysConfig error:%s", err)
|
e.Log.Errorf("Service RemoveSysConfig error:%s", err)
|
||||||
|
|||||||
@@ -4,7 +4,6 @@ import (
|
|||||||
"errors"
|
"errors"
|
||||||
log "github.com/go-admin-team/go-admin-core/logger"
|
log "github.com/go-admin-team/go-admin-core/logger"
|
||||||
"github.com/go-admin-team/go-admin-core/sdk/pkg"
|
"github.com/go-admin-team/go-admin-core/sdk/pkg"
|
||||||
|
|
||||||
"gorm.io/gorm"
|
"gorm.io/gorm"
|
||||||
|
|
||||||
"go-admin/app/admin/models/system"
|
"go-admin/app/admin/models/system"
|
||||||
@@ -85,9 +84,9 @@ func (e *SysDept) InsertSysDept(model *system.SysDept) error {
|
|||||||
// UpdateSysDept 修改SysDept对象
|
// UpdateSysDept 修改SysDept对象
|
||||||
func (e *SysDept) UpdateSysDept(c *system.SysDept) error {
|
func (e *SysDept) UpdateSysDept(c *system.SysDept) error {
|
||||||
var err error
|
var err error
|
||||||
var data system.SysDept
|
db := e.Orm.Model(&system.SysDept{
|
||||||
|
DeptId: c.GetId().(int),
|
||||||
db := e.Orm.Model(&data).
|
}).
|
||||||
Where(c.GetId()).Updates(c)
|
Where(c.GetId()).Updates(c)
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
e.Log.Errorf("db error:%s", err)
|
e.Log.Errorf("db error:%s", err)
|
||||||
@@ -97,9 +96,6 @@ func (e *SysDept) UpdateSysDept(c *system.SysDept) error {
|
|||||||
return errors.New("无权更新该数据")
|
return errors.New("无权更新该数据")
|
||||||
}
|
}
|
||||||
|
|
||||||
//参数1:是要修改的数据
|
|
||||||
//参数2:是修改的数据
|
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -108,8 +104,7 @@ func (e *SysDept) RemoveSysDept(d *dto.SysDeptById) error {
|
|||||||
var err error
|
var err error
|
||||||
var data system.SysDept
|
var data system.SysDept
|
||||||
|
|
||||||
db := e.Orm.Model(&data).
|
db := e.Orm.Model(&data).Delete(&data, d.GetId())
|
||||||
Where(d.GetId()).Delete(&data)
|
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
err = db.Error
|
err = db.Error
|
||||||
e.Log.Errorf("Delete error: %s", err)
|
e.Log.Errorf("Delete error: %s", err)
|
||||||
|
|||||||
@@ -71,10 +71,9 @@ func (e *SysDictData) Insert(model *system.SysDictData) error {
|
|||||||
// Update 修改对象
|
// Update 修改对象
|
||||||
func (e *SysDictData) Update(c *system.SysDictData) error {
|
func (e *SysDictData) Update(c *system.SysDictData) error {
|
||||||
var err error
|
var err error
|
||||||
var data system.SysDictData
|
db := e.Orm.Model(&system.SysDictData{
|
||||||
|
DictCode: c.GetId().(int),
|
||||||
db := e.Orm.Model(&data).
|
}).Updates(c)
|
||||||
Where(c.GetId()).Updates(c)
|
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
e.Log.Errorf("db error: %s", err)
|
e.Log.Errorf("db error: %s", err)
|
||||||
return err
|
return err
|
||||||
@@ -91,8 +90,7 @@ func (e *SysDictData) Remove(d *dto.SysDictDataById, c *system.SysDictData) erro
|
|||||||
var err error
|
var err error
|
||||||
var data system.SysDictData
|
var data system.SysDictData
|
||||||
|
|
||||||
db := e.Orm.Model(&data).
|
db := e.Orm.Model(&data).Delete(c, d.GetId())
|
||||||
Where(d.GetId()).Delete(c)
|
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
err = db.Error
|
err = db.Error
|
||||||
e.Log.Errorf("Delete error: %s", err)
|
e.Log.Errorf("Delete error: %s", err)
|
||||||
|
|||||||
@@ -71,10 +71,9 @@ func (e *SysDictType) Insert(model *system.SysDictType) error {
|
|||||||
// Update 修改对象
|
// Update 修改对象
|
||||||
func (e *SysDictType) Update(c *system.SysDictType) error {
|
func (e *SysDictType) Update(c *system.SysDictType) error {
|
||||||
var err error
|
var err error
|
||||||
var data system.SysDictType
|
db := e.Orm.Model(&system.SysDictType{
|
||||||
|
ID: c.GetId().(int),
|
||||||
db := e.Orm.Model(&data).
|
}).Updates(c)
|
||||||
Where(c.GetId()).Updates(c)
|
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
e.Log.Errorf("db error: %s", err)
|
e.Log.Errorf("db error: %s", err)
|
||||||
return err
|
return err
|
||||||
@@ -91,8 +90,7 @@ func (e *SysDictType) Remove(d *dto.SysDictTypeById, c *system.SysDictType) erro
|
|||||||
var err error
|
var err error
|
||||||
var data system.SysDictType
|
var data system.SysDictType
|
||||||
|
|
||||||
db := e.Orm.Model(&data).
|
db := e.Orm.Model(&data).Delete(c, d.GetId())
|
||||||
Where(d.GetId()).Delete(c)
|
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
err = db.Error
|
err = db.Error
|
||||||
e.Log.Errorf("Delete error: %s", err)
|
e.Log.Errorf("Delete error: %s", err)
|
||||||
|
|||||||
@@ -3,6 +3,7 @@ package service
|
|||||||
import (
|
import (
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"go-admin/app/admin/models/system"
|
||||||
|
|
||||||
"gorm.io/gorm"
|
"gorm.io/gorm"
|
||||||
|
|
||||||
@@ -91,10 +92,10 @@ func (e *SysFileDir) UpdateSysFileDir(c *dto.SysFileDirControl, p *actions.DataP
|
|||||||
var err error
|
var err error
|
||||||
data, _ := c.GenerateM()
|
data, _ := c.GenerateM()
|
||||||
|
|
||||||
db := e.Orm.
|
db := e.Orm.Model(&system.SysRole{RoleId: c.GetId().(int)}).
|
||||||
Scopes(
|
Scopes(
|
||||||
actions.Permission(data.TableName(), p),
|
actions.Permission(data.TableName(), p),
|
||||||
).Where(c.ID).Updates(data)
|
).Updates(data)
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
e.Log.Errorf("db error: %s", err)
|
e.Log.Errorf("db error: %s", err)
|
||||||
return err
|
return err
|
||||||
@@ -113,7 +114,7 @@ func (e *SysFileDir) RemoveSysFileDir(d *dto.SysFileDirById, p *actions.DataPerm
|
|||||||
db := e.Orm.Model(&data).
|
db := e.Orm.Model(&data).
|
||||||
Scopes(
|
Scopes(
|
||||||
actions.Permission(data.TableName(), p),
|
actions.Permission(data.TableName(), p),
|
||||||
).Where(d.Id).Delete(&data)
|
).Delete(&data, d.Id)
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
err = db.Error
|
err = db.Error
|
||||||
e.Log.Errorf("Delete error: %s", err)
|
e.Log.Errorf("Delete error: %s", err)
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ package service
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
"errors"
|
||||||
|
common "go-admin/common/models"
|
||||||
|
|
||||||
"gorm.io/gorm"
|
"gorm.io/gorm"
|
||||||
|
|
||||||
@@ -89,10 +90,12 @@ func (e *SysFileInfo) UpdateSysFileInfo(c *dto.SysFileInfoControl, p *actions.Da
|
|||||||
e.Log.Errorf("db error: %s", err)
|
e.Log.Errorf("db error: %s", err)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
err = e.Orm.Debug().Model(&data).
|
err = e.Orm.Debug().Model(&models.SysFileInfo{Model: common.Model{
|
||||||
|
Id: c.ID,
|
||||||
|
}}).
|
||||||
Scopes(
|
Scopes(
|
||||||
actions.Permission(data.TableName(), p),
|
actions.Permission(data.TableName(), p),
|
||||||
).Where("id = ?", c.ID).Updates(&data).Error
|
).Updates(&data).Error
|
||||||
if err != nil {
|
if err != nil {
|
||||||
e.Log.Errorf("db error: %s", err)
|
e.Log.Errorf("db error: %s", err)
|
||||||
return err
|
return err
|
||||||
@@ -112,7 +115,7 @@ func (e *SysFileInfo) RemoveSysFileInfo(d *dto.SysFileInfoById, p *actions.DataP
|
|||||||
db := e.Orm.Model(&data).
|
db := e.Orm.Model(&data).
|
||||||
Scopes(
|
Scopes(
|
||||||
actions.Permission(data.TableName(), p),
|
actions.Permission(data.TableName(), p),
|
||||||
).Where(d.GetId()).Delete(&data)
|
).Delete(&data, d.GetId())
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
err = db.Error
|
err = db.Error
|
||||||
e.Log.Errorf("Delete error: %s", err)
|
e.Log.Errorf("Delete error: %s", err)
|
||||||
|
|||||||
@@ -75,7 +75,7 @@ func (e *SysLoginLog) UpdateSysLoginLog(c common.ActiveRecord) error {
|
|||||||
var data system.SysLoginLog
|
var data system.SysLoginLog
|
||||||
|
|
||||||
db := e.Orm.Model(&data).
|
db := e.Orm.Model(&data).
|
||||||
Where(c.GetId()).Updates(c)
|
Where("id = ?", c.GetId()).Updates(c)
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
e.Log.Errorf("db error:%s", err)
|
e.Log.Errorf("db error:%s", err)
|
||||||
return err
|
return err
|
||||||
@@ -92,8 +92,7 @@ func (e *SysLoginLog) RemoveSysLoginLog(d *dto.SysLoginLogById, c common.ActiveR
|
|||||||
var err error
|
var err error
|
||||||
var data system.SysLoginLog
|
var data system.SysLoginLog
|
||||||
|
|
||||||
db := e.Orm.Model(&data).
|
db := e.Orm.Model(&data).Delete(c, d.Ids)
|
||||||
Where(d.Ids).Delete(c)
|
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
err = db.Error
|
err = db.Error
|
||||||
e.Log.Errorf("Delete error: %s", err)
|
e.Log.Errorf("Delete error: %s", err)
|
||||||
|
|||||||
@@ -107,7 +107,7 @@ func (e *SysMenu) UpdateSysMenu(c *system.SysMenu) error {
|
|||||||
var data system.SysMenu
|
var data system.SysMenu
|
||||||
|
|
||||||
db := e.Orm.Model(&data).
|
db := e.Orm.Model(&data).
|
||||||
Where(c.GetId()).Updates(c)
|
Where("menu_id = ?", c.GetId()).Updates(c)
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
e.Log.Errorf("db error:%s", err)
|
e.Log.Errorf("db error:%s", err)
|
||||||
return err
|
return err
|
||||||
@@ -124,8 +124,7 @@ func (e *SysMenu) RemoveSysMenu(d *dto.SysMenuById) error {
|
|||||||
var err error
|
var err error
|
||||||
var data system.SysMenu
|
var data system.SysMenu
|
||||||
|
|
||||||
db := e.Orm.Model(&data).
|
db := e.Orm.Model(&data).Delete(&data, d.GetId())
|
||||||
Where(d.GetId()).Delete(&data)
|
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
err = db.Error
|
err = db.Error
|
||||||
e.Log.Errorf("Delete error: %s", err)
|
e.Log.Errorf("Delete error: %s", err)
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import (
|
|||||||
"go-admin/app/admin/models/system"
|
"go-admin/app/admin/models/system"
|
||||||
"go-admin/app/admin/service/dto"
|
"go-admin/app/admin/service/dto"
|
||||||
cDto "go-admin/common/dto"
|
cDto "go-admin/common/dto"
|
||||||
|
common "go-admin/common/models"
|
||||||
"go-admin/common/service"
|
"go-admin/common/service"
|
||||||
"gorm.io/gorm"
|
"gorm.io/gorm"
|
||||||
)
|
)
|
||||||
@@ -68,8 +69,9 @@ func (e *SysOperaLog) InsertSysOperaLog(model *system.SysOperaLog) error {
|
|||||||
func (e *SysOperaLog) UpdateSysOperaLog(c *system.SysOperaLog) error {
|
func (e *SysOperaLog) UpdateSysOperaLog(c *system.SysOperaLog) error {
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
db := e.Orm.Model(c).
|
db := e.Orm.Model(&system.SysOperaLog{Model: common.Model{
|
||||||
Where(c.GetId()).Updates(c)
|
Id: c.GetId().(int),
|
||||||
|
}}).Updates(c)
|
||||||
if err = db.Error; err != nil {
|
if err = db.Error; err != nil {
|
||||||
e.Log.Errorf("Service UpdateSysOperaLog error:%s", err.Error())
|
e.Log.Errorf("Service UpdateSysOperaLog error:%s", err.Error())
|
||||||
return err
|
return err
|
||||||
@@ -86,7 +88,7 @@ func (e *SysOperaLog) RemoveSysOperaLog(d *dto.SysOperaLogById) error {
|
|||||||
var err error
|
var err error
|
||||||
var data system.SysOperaLog
|
var data system.SysOperaLog
|
||||||
|
|
||||||
db := e.Orm.Model(&data).Where(d.Ids).Delete(&data)
|
db := e.Orm.Model(&data).Delete(&data, d.Ids)
|
||||||
if err = db.Error; err != nil {
|
if err = db.Error; err != nil {
|
||||||
e.Log.Errorf("Service RemoveSysOperaLog error:%s", err.Error())
|
e.Log.Errorf("Service RemoveSysOperaLog error:%s", err.Error())
|
||||||
return err
|
return err
|
||||||
|
|||||||
@@ -74,7 +74,7 @@ func (e *SysPost) UpdateSysPost(c *system.SysPost) error {
|
|||||||
var data system.SysPost
|
var data system.SysPost
|
||||||
|
|
||||||
db := e.Orm.Model(&data).
|
db := e.Orm.Model(&data).
|
||||||
Where(c.GetId()).Updates(c)
|
Where("post_id = ?", c.GetId()).Updates(c)
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
e.Log.Errorf("db error:%s", err)
|
e.Log.Errorf("db error:%s", err)
|
||||||
return err
|
return err
|
||||||
|
|||||||
@@ -104,7 +104,7 @@ func (e *SysRole) UpdateSysRole(c *system.SysRole) error {
|
|||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
db := tx.Model(&c).
|
db := tx.Model(&c).
|
||||||
Where(c.GetId()).Updates(c)
|
Where(" role_id = ?", c.GetId()).Updates(c)
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
e.Log.Errorf("db error:%s", err)
|
e.Log.Errorf("db error:%s", err)
|
||||||
return err
|
return err
|
||||||
|
|||||||
@@ -83,7 +83,7 @@ func (e *SysUser) UpdateSysUser(c common.ActiveRecord, p *actions.DataPermission
|
|||||||
db := e.Orm.Model(c).
|
db := e.Orm.Model(c).
|
||||||
Scopes(
|
Scopes(
|
||||||
actions.Permission(c.TableName(), p),
|
actions.Permission(c.TableName(), p),
|
||||||
).Where(c.GetId()).Updates(c)
|
).Where("user_id = ?", c.GetId()).Updates(c)
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
e.Log.Errorf("db error: %s", err)
|
e.Log.Errorf("db error: %s", err)
|
||||||
return err
|
return err
|
||||||
@@ -103,7 +103,7 @@ func (e *SysUser) RemoveSysUser(d cDto.Control, c common.ActiveRecord, p *action
|
|||||||
db := e.Orm.Model(&data).
|
db := e.Orm.Model(&data).
|
||||||
Scopes(
|
Scopes(
|
||||||
actions.Permission(data.TableName(), p),
|
actions.Permission(data.TableName(), p),
|
||||||
).Where(d.GetId()).Delete(c)
|
).Delete(c, d.GetId())
|
||||||
if db.Error != nil {
|
if db.Error != nil {
|
||||||
err = db.Error
|
err = db.Error
|
||||||
e.Log.Errorf("Delete error: %s", err)
|
e.Log.Errorf("Delete error: %s", err)
|
||||||
@@ -128,7 +128,7 @@ func (e *SysUser) UpdateSysUserPwd(id int, oldPassword, newPassword string, p *a
|
|||||||
err = e.Orm.Model(c).
|
err = e.Orm.Model(c).
|
||||||
Scopes(
|
Scopes(
|
||||||
actions.Permission(c.TableName(), p),
|
actions.Permission(c.TableName(), p),
|
||||||
).Where(id).Select("UserId", "Password", "Salt").First(c).Error
|
).Where("user_id = ?", id).Select("UserId", "Password", "Salt").First(c).Error
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if errors.Is(err, gorm.ErrRecordNotFound) {
|
if errors.Is(err, gorm.ErrRecordNotFound) {
|
||||||
return errors.New("无权更新该数据")
|
return errors.New("无权更新该数据")
|
||||||
@@ -148,7 +148,7 @@ func (e *SysUser) UpdateSysUserPwd(id int, oldPassword, newPassword string, p *a
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
c.Password = newPassword
|
c.Password = newPassword
|
||||||
db := e.Orm.Model(c).Where(id).Select("Password", "Salt").Updates(c)
|
db := e.Orm.Model(c).Where("user_id = ?", id).Select("Password", "Salt").Updates(c)
|
||||||
if err = db.Error; err != nil {
|
if err = db.Error; err != nil {
|
||||||
e.Log.Errorf("db error: %s", err)
|
e.Log.Errorf("db error: %s", err)
|
||||||
return err
|
return err
|
||||||
|
|||||||
Reference in New Issue
Block a user