|
@@ -1,10 +1,10 @@
|
|
|
package sandbox
|
|
|
|
|
|
import (
|
|
|
+ "eta/eta_api/global"
|
|
|
"eta/eta_api/models/system"
|
|
|
"eta/eta_api/utils"
|
|
|
"fmt"
|
|
|
- "github.com/beego/beego/v2/client/orm"
|
|
|
"github.com/rdlucklib/rdluck_tools/paging"
|
|
|
"time"
|
|
|
)
|
|
@@ -47,26 +47,23 @@ type Sandbox struct {
|
|
|
|
|
|
// Update 沙盘字段变更
|
|
|
func (sandbox *Sandbox) Update(cols []string) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- _, err = o.Update(sandbox, cols...)
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
+ err = o.Select(cols).Updates(sandbox).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetSandboxById 根据沙盘id获取沙盘详情
|
|
|
func GetSandboxById(sandboxId int) (sandboxInfo *Sandbox, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := `select * from sandbox where sandbox_id = ? and is_delete = 0`
|
|
|
- err = o.Raw(sql, sandboxId).QueryRow(&sandboxInfo)
|
|
|
+ err = o.Raw(sql, sandboxId).First(&sandboxInfo).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// AddNewSandbox 添加一个新的沙盘
|
|
|
func AddNewSandbox(sandboxInfo *Sandbox, sandboxVersion *SandboxVersion, sandboxDraft *SandboxDraft) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- to, err := o.Begin()
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
+ to := o.Begin()
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
|
_ = to.Rollback()
|
|
@@ -75,37 +72,31 @@ func AddNewSandbox(sandboxInfo *Sandbox, sandboxVersion *SandboxVersion, sandbox
|
|
|
}
|
|
|
}()
|
|
|
|
|
|
- id, err := to.Insert(sandboxInfo)
|
|
|
+ err = to.Create(sandboxInfo).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
- sandboxInfo.SandboxId = int(id)
|
|
|
|
|
|
// 新增版本
|
|
|
sandboxVersion.SandboxId = sandboxInfo.SandboxId
|
|
|
- id, err = to.Insert(sandboxVersion)
|
|
|
+ err = to.Create(sandboxVersion).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
- sandboxVersion.SandboxVersionId = int(id)
|
|
|
|
|
|
// 新增草稿
|
|
|
sandboxDraft.SandboxId = sandboxInfo.SandboxId
|
|
|
- id, err = to.Insert(sandboxDraft)
|
|
|
+ err = to.Create(sandboxDraft).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
- sandboxDraft.SandboxDraftId = int(id)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// UpdateSandbox 更新沙盘
|
|
|
func UpdateSandbox(sandboxInfo *Sandbox, updateSandboxColumn []string, sandboxVersion *SandboxVersion, sandboxDraft *SandboxDraft) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- to, err := o.Begin()
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
+ to := o.Begin()
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
|
_ = to.Rollback()
|
|
@@ -114,36 +105,32 @@ func UpdateSandbox(sandboxInfo *Sandbox, updateSandboxColumn []string, sandboxVe
|
|
|
}
|
|
|
}()
|
|
|
|
|
|
- _, err = to.Update(sandboxInfo, updateSandboxColumn...)
|
|
|
+ err = to.Select(updateSandboxColumn).Updates(sandboxInfo).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// 新增版本
|
|
|
sandboxVersion.SandboxId = sandboxInfo.SandboxId
|
|
|
- id, err := to.Insert(sandboxVersion)
|
|
|
+ err = to.Create(sandboxVersion).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
- sandboxVersion.SandboxVersionId = int(id)
|
|
|
|
|
|
// 新增草稿
|
|
|
sandboxDraft.SandboxId = sandboxInfo.SandboxId
|
|
|
- id, err = to.Insert(sandboxDraft)
|
|
|
+ err = to.Create(sandboxDraft).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
- sandboxDraft.SandboxDraftId = int(id)
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// UpdateSandboxName 更新沙盘(仅仅更新名称)
|
|
|
func UpdateSandboxName(sandboxInfo *Sandbox, sandboxVersion *SandboxVersion, sandboxDraft *SandboxDraft, updateSandboxColumn, updateSandboxVersionColumn []string) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- to, err := o.Begin()
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
+ to := o.Begin()
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
|
_ = to.Rollback()
|
|
@@ -152,24 +139,23 @@ func UpdateSandboxName(sandboxInfo *Sandbox, sandboxVersion *SandboxVersion, san
|
|
|
}
|
|
|
}()
|
|
|
|
|
|
- _, err = to.Update(sandboxInfo, updateSandboxColumn...)
|
|
|
+ err = to.Select(updateSandboxColumn).Updates(sandboxInfo).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// 更新版本
|
|
|
- _, err = to.Update(sandboxVersion, updateSandboxVersionColumn...)
|
|
|
+ err = to.Select(updateSandboxVersionColumn).Updates(sandboxVersion).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// 新增草稿
|
|
|
sandboxDraft.SandboxId = sandboxInfo.SandboxId
|
|
|
- id, err := to.Insert(sandboxDraft)
|
|
|
+ err = to.Create(sandboxDraft).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
- sandboxDraft.SandboxDraftId = int(id)
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -196,18 +182,19 @@ type SandboxListItem struct {
|
|
|
|
|
|
// GetList 获取沙盘列表页
|
|
|
func GetList(condition string, pars []interface{}, startSize, pageSize int) (total int, list []*Sandbox, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := "select a.sandbox_id,a.name,a.code,a.pic_url,a.sys_user_id,a.sys_user_name,a.modify_time,a.create_time from sandbox as a where 1=1 AND a.is_delete = 0 "
|
|
|
sql += condition
|
|
|
sql += ` order by a.modify_time desc,a.sandbox_id desc`
|
|
|
|
|
|
totalSql := `select count(1) total from (` + sql + `) z `
|
|
|
- err = o.Raw(totalSql, pars).QueryRow(&total)
|
|
|
+ err = o.Raw(totalSql, pars...).Scan(&total).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
sql += ` LIMIT ?,? `
|
|
|
- _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&list)
|
|
|
+ pars = append(pars, startSize, pageSize)
|
|
|
+ err = o.Raw(sql, pars...).Find(&list).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -218,10 +205,10 @@ type SandboxSaveResp struct {
|
|
|
}
|
|
|
|
|
|
func GetSandboxAll() (list []*SandboxClassifyItems, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := `SELECT sandbox_id,sandbox_classify_id,name AS sandbox_classify_name, sort
|
|
|
FROM sandbox `
|
|
|
- _, err = o.Raw(sql).QueryRows(&list)
|
|
|
+ err = o.Raw(sql).Find(&list).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -243,16 +230,16 @@ func CheckOpSandboxPermission(sysUser *system.Admin, createUserId int) (ok bool)
|
|
|
|
|
|
// GetSandboxInfoByAdminId 获取所有我创建的沙盘,用于分类展示
|
|
|
func GetSandboxInfoByAdminId(adminId int) (items []*SandboxClassifyItems, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT sandbox_id,sandbox_classify_id,name AS sandbox_classify_name,code,
|
|
|
sys_user_id,sys_user_name
|
|
|
FROM sandbox where sys_user_id = ? ORDER BY sort asc,create_time ASC `
|
|
|
- _, err = o.Raw(sql, adminId).QueryRows(&items)
|
|
|
+ err = o.Raw(sql, adminId).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetSandboxClassify(sandboxClassifyId int) (sandbox_classify_id string, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := `SELECT GROUP_CONCAT(t.sandbox_classify_id) AS sandbox_classify_id FROM (
|
|
|
SELECT a.sandbox_classify_id FROM sandbox_classify AS a
|
|
|
WHERE a.sandbox_classify_id=?
|
|
@@ -266,7 +253,7 @@ func GetSandboxClassify(sandboxClassifyId int) (sandbox_classify_id string, err
|
|
|
WHERE
|
|
|
parent_id IN ( SELECT sandbox_classify_id FROM sandbox_classify WHERE parent_id = ? )
|
|
|
)AS t`
|
|
|
- err = o.Raw(sql, sandboxClassifyId, sandboxClassifyId, sandboxClassifyId).QueryRow(&sandbox_classify_id)
|
|
|
+ err = o.Raw(sql, sandboxClassifyId, sandboxClassifyId, sandboxClassifyId).Scan(&sandbox_classify_id).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -276,23 +263,24 @@ type SandboxListItems struct {
|
|
|
}
|
|
|
|
|
|
func GetSandboxListByCondition(condition string, pars []interface{}, startSize, pageSize int) (item []*SandboxListItems, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT * FROM sandbox WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
|
}
|
|
|
sql += " ORDER BY create_time DESC LIMIT ?,? "
|
|
|
- _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&item)
|
|
|
+ pars = append(pars, startSize, pageSize)
|
|
|
+ err = o.Raw(sql, pars...).Find(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetSandboxListCountByCondition(condition string, pars []interface{}) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT COUNT(1) AS count FROM sandbox WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
|
}
|
|
|
- err = o.Raw(sql, pars).QueryRow(&count)
|
|
|
+ err = o.Raw(sql, pars...).Scan(&count).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -302,21 +290,25 @@ type SandboxListResp struct {
|
|
|
}
|
|
|
|
|
|
func AddSandbox(item *Sandbox) (lastId int64, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- lastId, err = o.Insert(item)
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
+ err = o.Create(item).Error
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ lastId = int64(item.SandboxId)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetSandboxItemsByClassifyId(sandboxClassifyId int) (list []*SandboxClassifyItems, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := `SELECT sandbox_id,sandbox_classify_id,name AS sandbox_classify_name, sort
|
|
|
FROM sandbox WHERE sandbox_classify_id = ? AND is_delete = 0 ORDER BY sort `
|
|
|
- _, err = o.Raw(sql, sandboxClassifyId).QueryRows(&list)
|
|
|
+ err = o.Raw(sql, sandboxClassifyId).Find(&list).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetSandboxAllParentByClassifyId(sandboxClassifyId int) (ids string, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := `SELECT
|
|
|
GROUP_CONCAT(DISTINCT m.sandbox_classify_id ORDER BY m.level) AS ids
|
|
|
FROM
|
|
@@ -348,7 +340,7 @@ FROM
|
|
|
INNER JOIN sandbox_classify m
|
|
|
WHERE
|
|
|
sandbox_classify_id = vm._id `
|
|
|
- err = o.Raw(sql, sandboxClassifyId).QueryRow(&ids)
|
|
|
+ err = o.Raw(sql, sandboxClassifyId).Scan(&ids).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -360,54 +352,54 @@ type MoveSandboxReq struct {
|
|
|
}
|
|
|
|
|
|
func GetSandboxClassifyCountById(classifyId int) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := `SELECT count(1) AS count FROM sandbox_classify WHERE sandbox_classify_id=? `
|
|
|
- err = o.Raw(sql, classifyId).QueryRow(&count)
|
|
|
+ err = o.Raw(sql, classifyId).Scan(&count).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetSandboxByClassifyIdAndName 根据分类id和沙盘名获取图表信息
|
|
|
func GetSandboxByClassifyIdAndName(classifyId int, name string) (item *Sandbox, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT * FROM sandbox WHERE sandbox_classify_id = ? and name=? `
|
|
|
- err = o.Raw(sql, classifyId, name).QueryRow(&item)
|
|
|
+ err = o.Raw(sql, classifyId, name).First(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetSandboxNameByIds 根据沙盘名称
|
|
|
func GetSandboxNameByIds(ids []int) (items []*Sandbox, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT sandbox_id, name FROM sandbox WHERE sandbox_id in (` + utils.GetOrmInReplace(len(ids)) + `) `
|
|
|
- _, err = o.Raw(sql, ids).QueryRows(&items)
|
|
|
+ err = o.Raw(sql, ids).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func MoveSandbox(sandboxId, classifyId int) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` UPDATE sandbox
|
|
|
SET
|
|
|
sandbox_classify_id = ?
|
|
|
WHERE sandbox_id = ?`
|
|
|
- _, err = o.Raw(sql, classifyId, sandboxId).Exec()
|
|
|
+ err = o.Exec(sql, classifyId, sandboxId).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// UpdateSandboxSortByClassifyId 根据沙盘id更新排序
|
|
|
func UpdateSandboxSortByClassifyId(classifyId, nowSort, prevSandboxId int, updateSort string) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` update sandbox set sort = ` + updateSort + ` WHERE sandbox_classify_id=? AND `
|
|
|
if prevSandboxId > 0 {
|
|
|
sql += ` (sort > ? or (sandbox_id > ` + fmt.Sprint(prevSandboxId) + ` and sort = ` + fmt.Sprint(nowSort) + `))`
|
|
|
}
|
|
|
- _, err = o.Raw(sql, classifyId, nowSort).Exec()
|
|
|
+ err = o.Exec(sql, classifyId, nowSort).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetFirstSandboxByClassifyId 获取当前分类下,且排序数相同 的排序第一条的数据
|
|
|
func GetFirstSandboxByClassifyId(classifyId int) (item *Sandbox, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT * FROM sandbox WHERE sandbox_classify_id=? order by sort asc,sandbox_id asc limit 1`
|
|
|
- err = o.Raw(sql, classifyId).QueryRow(&item)
|
|
|
+ err = o.Raw(sql, classifyId).First(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -441,11 +433,8 @@ type DetailParams struct {
|
|
|
|
|
|
// UpdateSandboxContent 更新沙盘内容
|
|
|
func UpdateSandboxContent(list []Sandbox) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- to, err := o.Begin()
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
+ to := o.Begin()
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
|
_ = to.Rollback()
|
|
@@ -456,7 +445,7 @@ func UpdateSandboxContent(list []Sandbox) (err error) {
|
|
|
|
|
|
//循环更新沙盘内容
|
|
|
for _, sandbox := range list {
|
|
|
- _, err = to.Update(&sandbox, "Content", "ModifyTime")
|
|
|
+ err = to.Select([]string{"Content", "ModifyTime"}).Updates(&sandbox).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|