BaseSystem
/
Cron_Admin
12
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

db 修改

This commit is contained in:
wuchao 2024-11-28 11:53:25 +08:00
parent 39967329b3
commit 7cab8f82d7
2 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/http/entities/backend/db.go
View File

@ -34,7 +34,7 @@ type DbEditRequest struct {
DbName string `json:"db_name" validate:"required" form:"db_name" example:""` DbName string `json:"db_name" validate:"required" form:"db_name" example:""`
DbType string `json:"db_type" validate:"required" form:"db_type" example:"mysql"` DbType string `json:"db_type" validate:"required" form:"db_type" example:"mysql"`
DbPermission int `json:"db_permission" validate:"required" form:"db_permission" example:"1"` DbPermission int `json:"db_permission" validate:"required" form:"db_permission" example:"1"`
Source string `json:"source" validate:"required" form:"source" example:""` Source string `json:"source" form:"source" example:""`
Desc string `json:"desc" form:"desc" example:""` Desc string `json:"desc" form:"desc" example:""`
Status int `json:"status" form:"status" example:"1"` Status int `json:"status" form:"status" example:"1"`
} }

10
app/services/db_service/db_service.go
View File

@ -26,7 +26,7 @@ func DbList(request *backend.DbListRequest, page int, limit int) (count int64, D
if request.DbPermission != 0 { if request.DbPermission != 0 {
session = session.And(builder.Eq{"DbPermission": request.DbPermission}) session = session.And(builder.Eq{"DbPermission": request.DbPermission})
} }
count, err = session.Omit("source", "UpdateTime").FindAndCount(&DbListInfo) count, err = session.OrderBy("db_id desc").Omit("source", "UpdateTime").FindAndCount(&DbListInfo)
if err != nil { if err != nil {
return return
} }
@ -42,8 +42,16 @@ func DbAdd(request *backend.DbAddRequest) (err error) {
} }
func DbEdit(request *backend.DbEditRequest) (err error) { func DbEdit(request *backend.DbEditRequest) (err error) {
var info crondbmodel.CronDb
flag, _ := crondbmodel.GetInstance().GetDb().ID(request.DbId).Get(&info)
if !flag {
return
}
var db crondbmodel.CronDb var db crondbmodel.CronDb
_ = mapstructure.Decode(request, &db) _ = mapstructure.Decode(request, &db)
if request.Source == "" {
request.Source = info.Source
}
_, err = crondbmodel.GetInstance().GetDb().ID(request.DbId).Update(&db) _, err = crondbmodel.GetInstance().GetDb().ID(request.DbId).Update(&db)
return return
} }