|
@@ -1,9 +1,9 @@
|
|
|
package data_manage
|
|
|
|
|
|
import (
|
|
|
+ "eta/eta_api/global"
|
|
|
"eta/eta_api/utils"
|
|
|
"fmt"
|
|
|
- "github.com/beego/beego/v2/client/orm"
|
|
|
"github.com/rdlucklib/rdluck_tools/paging"
|
|
|
"time"
|
|
|
)
|
|
@@ -14,29 +14,30 @@ type ChartListResp struct {
|
|
|
}
|
|
|
|
|
|
func GetChartListByCondition(condition string, pars []interface{}, startSize, pageSize int) (item []*ChartInfoView, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT * FROM chart_info WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
|
}
|
|
|
//sql += " ORDER BY sort ASC,chart_info_id DESC LIMIT ?,? "
|
|
|
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 GetChartListCountByCondition(condition string, pars []interface{}) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT COUNT(1) AS count FROM chart_info WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
|
}
|
|
|
- err = o.Raw(sql, pars).QueryRow(&count)
|
|
|
+ err = o.Raw(sql, pars...).Scan(&count).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
type MyChartClassify struct {
|
|
|
- MyChartClassifyId int `orm:"column(my_chart_classify_id);pk"`
|
|
|
+ MyChartClassifyId int `orm:"column(my_chart_classify_id);pk" gorm:"primaryKey"`
|
|
|
MyChartClassifyName string
|
|
|
Sort int `json:"-" description:"排序字段,值越小,排的越靠前"`
|
|
|
AdminId int `description:"创建人id"`
|
|
@@ -49,24 +50,24 @@ type MyChartClassify struct {
|
|
|
}
|
|
|
|
|
|
func AddMyChartClassify(item *MyChartClassify) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- _, err = o.Insert(item)
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
+ err = o.Create(item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetMyChartClassifyAll(adminId int) (item []*MyChartClassify, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT * FROM my_chart_classify WHERE 1=1 AND admin_id=? `
|
|
|
sql += " ORDER BY sort asc, my_chart_classify_id asc "
|
|
|
- _, err = o.Raw(sql, adminId).QueryRows(&item)
|
|
|
+ err = o.Raw(sql, adminId).Find(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetPublicChartClassifyAllExceptMy(adminId int) (item []*MyChartClassify, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT * FROM my_chart_classify WHERE 1=1 AND is_public=1 AND admin_id !=?`
|
|
|
sql += " ORDER BY public_time asc"
|
|
|
- _, err = o.Raw(sql, adminId).QueryRows(&item)
|
|
|
+ err = o.Raw(sql, adminId).Find(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -103,35 +104,35 @@ type MyChartClassifyAddReq struct {
|
|
|
}
|
|
|
|
|
|
func GetMyChartClassifyCountByCondition(condition string, pars []interface{}) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT COUNT(1) AS count FROM my_chart_classify WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
|
}
|
|
|
- err = o.Raw(sql, pars).QueryRow(&count)
|
|
|
+ err = o.Raw(sql, pars...).Scan(&count).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetMyChartClassifyById(adminId, myChartClassifyId int) (item *MyChartClassify, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT * FROM my_chart_classify WHERE admin_id=? AND my_chart_classify_id=? `
|
|
|
- err = o.Raw(sql, adminId, myChartClassifyId).QueryRow(&item)
|
|
|
+ err = o.Raw(sql, adminId, myChartClassifyId).Find(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetMyChartClassifyMastSort 获取MY ETA 分类中排序最大的值
|
|
|
func GetMyChartClassifyMastSort(adminId int) (sort int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT MAX(sort) sort FROM my_chart_classify WHERE admin_id=? `
|
|
|
- err = o.Raw(sql, adminId).QueryRow(&sort)
|
|
|
+ err = o.Raw(sql, adminId).Scan(&sort).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetMyChartClassifyMinSort 获取MY ETA 分类中排序最小的值
|
|
|
func GetMyChartClassifyMinSort(adminId int) (sort int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT MIN(sort) sort FROM my_chart_classify WHERE admin_id=? `
|
|
|
- err = o.Raw(sql, adminId).QueryRow(&sort)
|
|
|
+ err = o.Raw(sql, adminId).Scan(&sort).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -148,9 +149,9 @@ type MyChartClassifyMoveReq struct {
|
|
|
}
|
|
|
|
|
|
func ModifyMyChartClassify(myChartClassifyId int, myChartClassifyName string) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := `UPDATE my_chart_classify SET my_chart_classify_name=?,modify_time=NOW() WHERE my_chart_classify_id=?`
|
|
|
- _, err = o.Raw(sql, myChartClassifyName, myChartClassifyId).Exec()
|
|
|
+ err = o.Exec(sql, myChartClassifyName, myChartClassifyId).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -159,7 +160,7 @@ type MyChartClassifyDeleteReq struct {
|
|
|
}
|
|
|
|
|
|
func DeleteMyChartClassify(myChartClassifyId int) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
//o.Begin()
|
|
|
//
|
|
|
//defer func() {
|
|
@@ -171,29 +172,29 @@ func DeleteMyChartClassify(myChartClassifyId int) (err error) {
|
|
|
//}()
|
|
|
|
|
|
sql := `DELETE FROM my_chart_classify WHERE my_chart_classify_id=?`
|
|
|
- _, err = o.Raw(sql, myChartClassifyId).Exec()
|
|
|
+ err = o.Exec(sql, myChartClassifyId).Error
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
|
mappingList := make([]*MyChartClassifyMapping, 0)
|
|
|
sql = `SELECT * FROM my_chart_classify_mapping WHERE my_chart_classify_id=?`
|
|
|
- _, err = o.Raw(sql, myChartClassifyId).QueryRows(&mappingList)
|
|
|
+ err = o.Raw(sql, myChartClassifyId).Find(&mappingList).Error
|
|
|
|
|
|
sql = `DELETE FROM my_chart_classify_mapping WHERE my_chart_classify_id=?`
|
|
|
- _, err = o.Raw(sql, myChartClassifyId).Exec()
|
|
|
+ err = o.Exec(sql, myChartClassifyId).Error
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
|
for _, v := range mappingList {
|
|
|
var count int
|
|
|
sql = ` SELECT COUNT(1) AS count FROM my_chart_classify_mapping WHERE my_chart_id=?`
|
|
|
- err = o.Raw(sql, v.MyChartId).QueryRow(&count)
|
|
|
+ err = o.Raw(sql, v.MyChartId).Scan(&count).Error
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
|
if count <= 0 {
|
|
|
sql = `DELETE FROM my_chart WHERE my_chart_id=?`
|
|
|
- _, err = o.Raw(sql, v.MyChartId).Exec()
|
|
|
+ err = o.Exec(sql, v.MyChartId).Error
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
@@ -213,7 +214,7 @@ type MyChartAddResp struct {
|
|
|
}
|
|
|
|
|
|
type MyChart struct {
|
|
|
- MyChartId int `orm:"column(my_chart_id);pk"`
|
|
|
+ MyChartId int `orm:"column(my_chart_id);pk" gorm:"primaryKey"`
|
|
|
ChartInfoId int `description:"图表id"`
|
|
|
Source int `description:"1:ETA图库;2:商品价格"`
|
|
|
AdminId int `description:"用户id"`
|
|
@@ -222,7 +223,7 @@ type MyChart struct {
|
|
|
}
|
|
|
|
|
|
type MyChartView struct {
|
|
|
- MyChartId int `orm:"column(my_chart_id);pk"`
|
|
|
+ MyChartId int `orm:"column(my_chart_id);pk" gorm:"primaryKey"`
|
|
|
ChartInfoId int `description:"图表id"`
|
|
|
AdminId int `description:"用户id"`
|
|
|
CreateTime time.Time `description:"创建时间"`
|
|
@@ -231,13 +232,17 @@ type MyChartView struct {
|
|
|
}
|
|
|
|
|
|
func AddMyChart(item *MyChart) (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.MyChartId)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
type MyChartClassifyMapping struct {
|
|
|
- MyChartClassifyMappingId int `orm:"column(my_chart_classify_mapping_id);pk"`
|
|
|
+ MyChartClassifyMappingId int `orm:"column(my_chart_classify_mapping_id);pk" gorm:"primaryKey"`
|
|
|
AdminId int
|
|
|
MyChartId int
|
|
|
MyChartClassifyId int
|
|
@@ -247,15 +252,19 @@ type MyChartClassifyMapping struct {
|
|
|
}
|
|
|
|
|
|
func AddMyChartClassifyMapping(item *MyChartClassifyMapping) (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.MyChartClassifyMappingId)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetMyChartClassifyMapping(adminId, myChartId, myChartClassifyId int) (item *MyChartClassifyMapping, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := `SELECT * FROM my_chart_classify_mapping WHERE admin_id=? AND my_chart_id=? AND my_chart_classify_id=? `
|
|
|
- err = o.Raw(sql, adminId, myChartId, myChartClassifyId).QueryRow(&item)
|
|
|
+ err = o.Raw(sql, adminId, myChartId, myChartClassifyId).Find(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -265,22 +274,22 @@ type MyChartDeleteReq struct {
|
|
|
}
|
|
|
|
|
|
func DeleteMyChart(myChartId, myChartClassifyId int) (isDelMyChart bool, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
if myChartClassifyId > 0 {
|
|
|
sql := `DELETE FROM my_chart_classify_mapping WHERE my_chart_id=? AND my_chart_classify_id=? `
|
|
|
- _, err = o.Raw(sql, myChartId, myChartClassifyId).Exec()
|
|
|
+ err = o.Exec(sql, myChartId, myChartClassifyId).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
var count int
|
|
|
sql = ` SELECT COUNT(1) AS count FROM my_chart_classify_mapping WHERE my_chart_id=? `
|
|
|
- err = o.Raw(sql, myChartId).QueryRow(&count)
|
|
|
+ err = o.Raw(sql, myChartId).Scan(&count).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
if count <= 0 {
|
|
|
sql = `DELETE FROM my_chart WHERE my_chart_id=? `
|
|
|
- _, err = o.Raw(sql, myChartId).Exec()
|
|
|
+ err = o.Exec(sql, myChartId).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -288,7 +297,7 @@ func DeleteMyChart(myChartId, myChartClassifyId int) (isDelMyChart bool, err err
|
|
|
}
|
|
|
} else {
|
|
|
sql := `DELETE FROM my_chart WHERE my_chart_id=? `
|
|
|
- _, err = o.Raw(sql, myChartId).Exec()
|
|
|
+ err = o.Exec(sql, myChartId).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -338,7 +347,7 @@ type MyChartListResp struct {
|
|
|
}
|
|
|
|
|
|
func GetMyChartListByCondition(condition string, pars []interface{}, startSize, pageSize int) (item []*MyChartList, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
|
|
|
field := `a.my_chart_id,c.admin_id,c.sort,c.create_time as c_ctime,b.chart_info_id,b.chart_name,b.chart_name_en,b.chart_classify_id,b.sys_user_id,b.sys_user_real_name,b.unique_code,b.create_time,b.modify_time,b.date_type,b.start_date,b.end_date,b.is_set_name,b.edb_info_ids,b.chart_type,b.calendar,b.season_start_date,b.season_end_date,b.chart_image,b.edb_end_date,b.disabled,b.source,b.is_join_permission `
|
|
|
//MyChartClassifyName string `description:"分类名称,多个用英文逗号分割"`
|
|
@@ -352,12 +361,13 @@ func GetMyChartListByCondition(condition string, pars []interface{}, startSize,
|
|
|
sql += condition
|
|
|
}
|
|
|
sql += " GROUP BY a.chart_info_id) AS f ORDER BY sort ASC,c_ctime 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 GetMyChartListCountByCondition(condition string, pars []interface{}) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` select a.* from my_chart AS a
|
|
|
INNER JOIN chart_info AS b ON a.chart_info_id=b.chart_info_id
|
|
|
INNER JOIN my_chart_classify_mapping AS c ON a.my_chart_id=c.my_chart_id
|
|
@@ -367,14 +377,14 @@ func GetMyChartListCountByCondition(condition string, pars []interface{}) (count
|
|
|
sql += condition
|
|
|
}
|
|
|
sql1 := ` SELECT COUNT(1) AS count FROM (` + sql + ` GROUP BY a.chart_info_id ) d`
|
|
|
- err = o.Raw(sql1, pars).QueryRow(&count)
|
|
|
+ err = o.Raw(sql1, pars...).Scan(&count).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetMyChartMaxSort(adminId, myChartClassifyId int) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT COUNT(1) AS count FROM my_chart_classify_mapping WHERE 1=1 AND admin_id=? AND my_chart_classify_id=? `
|
|
|
- err = o.Raw(sql, adminId, myChartClassifyId).QueryRow(&count)
|
|
|
+ err = o.Raw(sql, adminId, myChartClassifyId).Scan(&count).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -386,27 +396,27 @@ type MoveMyChartReq struct {
|
|
|
}
|
|
|
|
|
|
func MyChartMove(sort float64, adminId int, myChartId, myChartClassifyId int) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` UPDATE my_chart_classify_mapping SET sort = ?,modify_time=NOW() WHERE admin_id=? AND my_chart_id=? AND my_chart_classify_id=? `
|
|
|
- _, err = o.Raw(sql, sort, adminId, myChartId, myChartClassifyId).Exec()
|
|
|
+ err = o.Exec(sql, sort, adminId, myChartId, myChartClassifyId).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// UpdateMyChartSortByClassifyId 根据分类id更新排序
|
|
|
func UpdateMyChartSortByClassifyId(myChartClassifyId, nowSort int, prevMyChartClassifyMappingId int, updateSort string) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` update my_chart_classify_mapping set sort = ` + updateSort + ` WHERE my_chart_classify_id=? AND `
|
|
|
if prevMyChartClassifyMappingId > 0 {
|
|
|
sql += ` ( sort > ? or ( my_chart_classify_mapping_id < ? and sort=? )) `
|
|
|
}
|
|
|
- _, err = o.Raw(sql, myChartClassifyId, nowSort, prevMyChartClassifyMappingId, nowSort).Exec()
|
|
|
+ err = o.Exec(sql, myChartClassifyId, nowSort, prevMyChartClassifyMappingId, nowSort).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetMyChartMinSortByAdminId(adminId int) (item *MyChart, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT * FROM my_chart WHERE admin_id=? ORDER BY sort ASC LIMIT 1`
|
|
|
- err = o.Raw(sql, adminId).QueryRow(&item)
|
|
|
+ err = o.Raw(sql, adminId).Find(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -415,7 +425,7 @@ type ChartRecommendListResp struct {
|
|
|
}
|
|
|
|
|
|
func GetChartClassify(chartClassifyId int) (chart_classify_id string, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := `SELECT GROUP_CONCAT(t.chart_classify_id) AS chart_classify_id FROM (
|
|
|
SELECT a.chart_classify_id FROM chart_classify AS a
|
|
|
WHERE a.chart_classify_id=?
|
|
@@ -429,24 +439,25 @@ func GetChartClassify(chartClassifyId int) (chart_classify_id string, err error)
|
|
|
WHERE
|
|
|
parent_id IN ( SELECT chart_classify_id FROM chart_classify WHERE parent_id = ? )
|
|
|
)AS t`
|
|
|
- err = o.Raw(sql, chartClassifyId, chartClassifyId, chartClassifyId).QueryRow(&chart_classify_id)
|
|
|
+ err = o.Raw(sql, chartClassifyId, chartClassifyId, chartClassifyId).Scan(&chart_classify_id).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetRecommendChartListByCondition(condition string, pars []interface{}, startSize, pageSize int) (item []*ChartInfoView, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT b.* FROM my_chart AS a
|
|
|
INNER JOIN chart_info AS b ON a.chart_info_id=b.chart_info_id `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
|
}
|
|
|
sql += " ORDER BY a.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 GetMyChartListByAdminId(adminId int) (item []*MyChartView, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
//sql := ` SELECT * FROM my_chart WHERE 1=1 AND admin_id=? `
|
|
|
|
|
|
sql := ` SELECT a.*,GROUP_CONCAT(c.my_chart_classify_id SEPARATOR ',') AS my_chart_classify_id FROM my_chart AS a
|
|
@@ -454,12 +465,12 @@ func GetMyChartListByAdminId(adminId int) (item []*MyChartView, err error) {
|
|
|
LEFT JOIN my_chart_classify AS c ON b.my_chart_classify_id=c.my_chart_classify_id AND b.admin_id=c.admin_id
|
|
|
WHERE 1=1 AND a.admin_id=?
|
|
|
GROUP BY a.chart_info_id `
|
|
|
- _, err = o.Raw(sql, adminId).QueryRows(&item)
|
|
|
+ err = o.Raw(sql, adminId).Find(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetMyChartSearchByCondition(condition string, pars []interface{}) (item []*MyChartList, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT a.my_chart_id,c.sort,b.*,GROUP_CONCAT(DISTINCT d.my_chart_classify_name) AS my_chart_classify_name,GROUP_CONCAT(DISTINCT d.my_chart_classify_id) AS my_chart_classify_id
|
|
|
FROM my_chart AS a
|
|
|
INNER JOIN chart_info AS b ON a.chart_info_id=b.chart_info_id
|
|
@@ -471,7 +482,7 @@ func GetMyChartSearchByCondition(condition string, pars []interface{}) (item []*
|
|
|
sql += condition
|
|
|
}
|
|
|
sql += " GROUP BY a.chart_info_id ORDER BY c.sort DESC "
|
|
|
- _, err = o.Raw(sql, pars).QueryRows(&item)
|
|
|
+ err = o.Raw(sql, pars...).Find(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -487,36 +498,36 @@ type MyChartEditReq struct {
|
|
|
}
|
|
|
|
|
|
func GetMyChartClassifyMappingCount(adminId, myChartId, myChartClassifyId int) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT COUNT(1) AS count
|
|
|
FROM my_chart_classify_mapping
|
|
|
WHERE 1=1 AND admin_id=? AND my_chart_id=? AND my_chart_classify_id=? `
|
|
|
- err = o.Raw(sql, adminId, myChartId, myChartClassifyId).QueryRow(&count)
|
|
|
+ err = o.Raw(sql, adminId, myChartId, myChartClassifyId).Scan(&count).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func DeleteMyChartClassifyMapping(adminId, myChartId, myChartClassifyId int) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` DELETE FROM my_chart_classify_mapping
|
|
|
WHERE admin_id=? AND my_chart_id=? AND my_chart_classify_id=? `
|
|
|
- _, err = o.Raw(sql, adminId, myChartId, myChartClassifyId).Exec()
|
|
|
+ err = o.Exec(sql, adminId, myChartId, myChartClassifyId).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetMyChartSort(adminId, myChartClassifyId, sort int) (item *MyChartClassifyMapping, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT * FROM my_chart_classify_mapping WHERE 1=1 AND admin_id=? AND my_chart_classify_id=? `
|
|
|
if sort == 1 {
|
|
|
sql += ` ORDER BY sort DESC,my_chart_classify_mapping_id ASC LIMIT 1 `
|
|
|
} else {
|
|
|
sql += ` ORDER BY sort ASC,my_chart_classify_mapping_id DESC LIMIT 1 `
|
|
|
}
|
|
|
- err = o.Raw(sql, adminId, myChartClassifyId).QueryRow(&item)
|
|
|
+ err = o.Raw(sql, adminId, myChartClassifyId).Find(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetMyChartByCondition(condition string, pars []interface{}) (item []*MyChartView, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
//sql := ` SELECT * FROM my_chart WHERE 1=1 `
|
|
|
sql := `SELECT a.*,GROUP_CONCAT(c.my_chart_classify_id SEPARATOR ',') AS my_chart_classify_id FROM my_chart AS a
|
|
|
LEFT JOIN my_chart_classify_mapping AS b ON a.my_chart_id=b.my_chart_id AND a.admin_id=b.admin_id
|
|
@@ -527,26 +538,24 @@ func GetMyChartByCondition(condition string, pars []interface{}) (item []*MyChar
|
|
|
sql += condition
|
|
|
}
|
|
|
sql += ` GROUP BY a.chart_info_id `
|
|
|
- _, err = o.Raw(sql, pars).QueryRows(&item)
|
|
|
+ err = o.Raw(sql, pars...).Find(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetMyChartDetailByCondition(condition string, pars []interface{}) (item *MyChartView, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT * FROM my_chart WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
|
}
|
|
|
- err = o.Raw(sql, pars).QueryRow(&item)
|
|
|
+ err = o.Raw(sql, pars...).Find(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func MoveMyChartClassify(adminId, myChartId int, myChartClassifyId []int) (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()
|
|
@@ -561,21 +570,21 @@ func MoveMyChartClassify(adminId, myChartId int, myChartClassifyId []int) (err e
|
|
|
|
|
|
mappingList := make([]*MyChartClassifyMapping, 0)
|
|
|
sql := `SELECT * FROM my_chart_classify_mapping WHERE admin_id=? AND my_chart_id=?`
|
|
|
- _, err = to.Raw(sql, adminId, myChartId).QueryRows(&mappingList)
|
|
|
+ err = to.Raw(sql, adminId, myChartId).Find(&mappingList).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
for _, v := range mappingList {
|
|
|
if _, ok := classifyIdMap[v.MyChartClassifyId]; !ok {
|
|
|
sql := ` DELETE FROM my_chart_classify_mapping WHERE my_chart_classify_mapping_id=? `
|
|
|
- _, err = to.Raw(sql, v.MyChartClassifyMappingId).Exec()
|
|
|
+ err = to.Exec(sql, v.MyChartClassifyMappingId).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
//sql := `DELETE FROM my_chart_classify_mapping WHERE admin_id=? AND my_chart_id=? `
|
|
|
- //_, err = to.Raw(sql, adminId, myChartId).Exec()
|
|
|
+ //err = to.Exec(sql, adminId, myChartId).Error
|
|
|
//if err != nil {
|
|
|
// return err
|
|
|
//}
|
|
@@ -583,7 +592,7 @@ func MoveMyChartClassify(adminId, myChartId int, myChartClassifyId []int) (err e
|
|
|
for _, v := range myChartClassifyId {
|
|
|
var count int
|
|
|
sql := ` SELECT COUNT(1) AS count FROM my_chart_classify_mapping WHERE my_chart_id=? AND my_chart_classify_id=? `
|
|
|
- err = to.Raw(sql, myChartId, v).QueryRow(&count)
|
|
|
+ err = to.Raw(sql, myChartId, v).Scan(&count).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -601,7 +610,7 @@ func MoveMyChartClassify(adminId, myChartId int, myChartClassifyId []int) (err e
|
|
|
create_time,
|
|
|
modify_time,
|
|
|
sort )VALUES (?,?,?,NOW(),NOW(),?) `
|
|
|
- _, err = to.Raw(sql, adminId, myChartId, v, sort).Exec()
|
|
|
+ err = to.Exec(sql, adminId, myChartId, v, sort).Error
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
@@ -613,27 +622,27 @@ func MoveMyChartClassify(adminId, myChartId int, myChartClassifyId []int) (err e
|
|
|
|
|
|
// Update 更新分类基础信息
|
|
|
func (myChartClassify *MyChartClassify) Update(cols []string) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- _, err = o.Update(myChartClassify, cols...)
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
+ err = o.Select(cols).Updates(myChartClassify).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetFirstMyChartClassifyByAdminId 获取当前账号下,排序第一条的分类数据
|
|
|
func GetFirstMyChartClassifyByAdminId(adminId int) (item *MyChartClassify, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT * FROM my_chart_classify WHERE admin_id=? order by sort asc,my_chart_classify_id asc limit 1`
|
|
|
- err = o.Raw(sql, adminId).QueryRow(&item)
|
|
|
+ err = o.Raw(sql, adminId).Find(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// UpdateMyChartClassifySortByClassifyId 根据分类id更新排序
|
|
|
func UpdateMyChartClassifySortByClassifyId(adminId, classifyId, nowSort int, updateSort string) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` update my_chart_classify set sort = ` + updateSort + ` WHERE admin_id = ? and sort > ? `
|
|
|
if classifyId > 0 {
|
|
|
sql += ` or ( my_chart_classify_id > ` + fmt.Sprint(classifyId) + ` and sort = ` + fmt.Sprint(nowSort) + `)`
|
|
|
}
|
|
|
- _, err = o.Raw(sql, adminId, nowSort).Exec()
|
|
|
+ err = o.Exec(sql, adminId, nowSort).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -650,19 +659,16 @@ type CopyChartClassifyReq struct {
|
|
|
|
|
|
// GetPublicMyChartClassifyById 根据分类ID获取公开分类
|
|
|
func GetPublicMyChartClassifyById(myChartClassifyId int) (item *MyChartClassify, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT * FROM my_chart_classify WHERE is_public=1 AND my_chart_classify_id=? `
|
|
|
- err = o.Raw(sql, myChartClassifyId).QueryRow(&item)
|
|
|
+ err = o.Raw(sql, myChartClassifyId).Find(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// CopyPublicMyChartClassifyById 根据分类ID获取公开分类
|
|
|
func CopyPublicMyChartClassifyById(myChartClassifyId, adminId int, newMyChartClassifyName string) (newMyChartClassify *MyChartClassify, 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()
|
|
@@ -674,7 +680,7 @@ func CopyPublicMyChartClassifyById(myChartClassifyId, adminId int, newMyChartCla
|
|
|
//获取分类里面所有的图表信息
|
|
|
fromMappingList := make([]*MyChartClassifyMapping, 0)
|
|
|
sql := `SELECT * FROM my_chart_classify_mapping WHERE my_chart_classify_id=?`
|
|
|
- _, err = to.Raw(sql, myChartClassifyId).QueryRows(&fromMappingList)
|
|
|
+ err = to.Raw(sql, myChartClassifyId).Find(&fromMappingList).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -686,7 +692,7 @@ func CopyPublicMyChartClassifyById(myChartClassifyId, adminId int, newMyChartCla
|
|
|
|
|
|
var minSort int
|
|
|
sql = ` SELECT MIN(sort) sort FROM my_chart_classify WHERE admin_id=? `
|
|
|
- err = o.Raw(sql, adminId).QueryRow(&minSort)
|
|
|
+ err = o.Raw(sql, adminId).Scan(&minSort).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -695,7 +701,7 @@ func CopyPublicMyChartClassifyById(myChartClassifyId, adminId int, newMyChartCla
|
|
|
fromMyChartList := make([]*MyChart, 0)
|
|
|
sql = `SELECT a.* FROM my_chart a join my_chart_classify_mapping b on a.my_chart_id=b.my_chart_id
|
|
|
WHERE b.my_chart_classify_id=?`
|
|
|
- _, err = to.Raw(sql, myChartClassifyId).QueryRows(&fromMyChartList)
|
|
|
+ err = to.Raw(sql, myChartClassifyId).Find(&fromMyChartList).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -708,11 +714,11 @@ WHERE b.my_chart_classify_id=?`
|
|
|
ModifyTime: time.Now(),
|
|
|
Sort: minSort - 1,
|
|
|
}
|
|
|
- newMyChartClassifyId, err := to.Insert(newMyChartClassify)
|
|
|
+ err = to.Create(newMyChartClassify).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
-
|
|
|
+ newMyChartClassifyId := newMyChartClassify.MyChartClassifyId
|
|
|
newMappingList := make([]*MyChartClassifyMapping, 0)
|
|
|
|
|
|
//将图表加入我的图库
|
|
@@ -724,11 +730,11 @@ WHERE b.my_chart_classify_id=?`
|
|
|
CreateTime: time.Now(),
|
|
|
ModifyTime: time.Now(),
|
|
|
}
|
|
|
- tmpMyChartId, tmpErr := to.Insert(tmpMyChart)
|
|
|
+ tmpErr := to.Create(tmpMyChart).Error
|
|
|
if tmpErr != nil {
|
|
|
err = tmpErr
|
|
|
}
|
|
|
- tmpMyChart.MyChartId = int(tmpMyChartId)
|
|
|
+ tmpMyChartId := tmpMyChart.MyChartId
|
|
|
|
|
|
// 往自己的分类里面新增图表关系
|
|
|
|
|
@@ -749,7 +755,7 @@ WHERE b.my_chart_classify_id=?`
|
|
|
}
|
|
|
|
|
|
if len(newMappingList) > 0 {
|
|
|
- _, err = to.InsertMulti(len(newMappingList), newMappingList)
|
|
|
+ err = to.CreateInBatches(newMappingList, utils.MultiAddNum).Error
|
|
|
}
|
|
|
return
|
|
|
}
|
|
@@ -762,17 +768,17 @@ type ModifyChartClassifyCompanyPublicReq struct {
|
|
|
|
|
|
// GetCompanyPublicClassifyList 获取用户可见的分类列表
|
|
|
func GetCompanyPublicClassifyList(condition string, pars []interface{}) (item []*MyChartClassify, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT * FROM my_chart_classify WHERE 1 = 1 AND is_public = 1 AND is_company_public = 1 `
|
|
|
sql += condition
|
|
|
sql += " ORDER BY public_time asc"
|
|
|
- _, err = o.Raw(sql, pars).QueryRows(&item)
|
|
|
+ err = o.Raw(sql, pars...).Find(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetMyChartClassifyList 获取我的图表关联的分类列表数据
|
|
|
func GetMyChartClassifyList(myChartClassifyId int) (mappingList []*MyChartClassifyMapping, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
//o.Begin()
|
|
|
//
|
|
|
//defer func() {
|
|
@@ -783,13 +789,13 @@ func GetMyChartClassifyList(myChartClassifyId int) (mappingList []*MyChartClassi
|
|
|
// }
|
|
|
//}()
|
|
|
sql := `SELECT * FROM my_chart_classify_mapping WHERE my_chart_id=?`
|
|
|
- _, err = o.Raw(sql, myChartClassifyId).QueryRows(&mappingList)
|
|
|
+ err = o.Raw(sql, myChartClassifyId).Find(&mappingList).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// AddMyChartToMyChartClassify 添加我的图表至我的分类
|
|
|
func AddMyChartToMyChartClassify(adminId, myChartId int, myChartClassifyId []int) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
//o.Begin()
|
|
|
|
|
|
//defer func() {
|
|
@@ -808,7 +814,7 @@ func AddMyChartToMyChartClassify(adminId, myChartId int, myChartClassifyId []int
|
|
|
//查询已存在系统中的图表分类集合
|
|
|
mappingList := make([]*MyChartClassifyMapping, 0)
|
|
|
sql := `SELECT * FROM my_chart_classify_mapping WHERE admin_id=? AND my_chart_id=?`
|
|
|
- _, err = o.Raw(sql, adminId, myChartId).QueryRows(&mappingList)
|
|
|
+ err = o.Raw(sql, adminId, myChartId).Find(&mappingList).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -823,7 +829,7 @@ func AddMyChartToMyChartClassify(adminId, myChartId int, myChartClassifyId []int
|
|
|
for _, v := range myChartClassifyId {
|
|
|
var count int
|
|
|
sql := ` SELECT COUNT(1) AS count FROM my_chart_classify_mapping WHERE my_chart_id=? AND my_chart_classify_id=? `
|
|
|
- err = o.Raw(sql, myChartId, v).QueryRow(&count)
|
|
|
+ err = o.Raw(sql, myChartId, v).Scan(&count).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -840,7 +846,7 @@ func AddMyChartToMyChartClassify(adminId, myChartId int, myChartClassifyId []int
|
|
|
create_time,
|
|
|
modify_time,
|
|
|
sort )VALUES (?,?,?,NOW(),NOW(),?) `
|
|
|
- _, err = o.Raw(sql, adminId, myChartId, v, sort).Exec()
|
|
|
+ err = o.Exec(sql, adminId, myChartId, v, sort).Error
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
@@ -852,7 +858,7 @@ func AddMyChartToMyChartClassify(adminId, myChartId int, myChartClassifyId []int
|
|
|
|
|
|
// GetMyChartListGroupByCharyInfoIdAndAdminIdByCondition 获取MY ETA 图表数据,根据图表id和操作员id
|
|
|
func GetMyChartListGroupByCharyInfoIdAndAdminIdByCondition(condition string, pars []interface{}) (item []*MyChartList, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT a.admin_id,a.my_chart_id,c.sort,b.*,GROUP_CONCAT(DISTINCT d.my_chart_classify_name) AS my_chart_classify_name,GROUP_CONCAT(DISTINCT d.my_chart_classify_id) AS my_chart_classify_id
|
|
|
FROM my_chart AS a
|
|
|
INNER JOIN chart_info AS b ON a.chart_info_id=b.chart_info_id
|
|
@@ -864,12 +870,12 @@ func GetMyChartListGroupByCharyInfoIdAndAdminIdByCondition(condition string, par
|
|
|
sql += condition
|
|
|
}
|
|
|
sql += " GROUP BY a.chart_info_id,a.admin_id ORDER BY c.sort DESC "
|
|
|
- _, err = o.Raw(sql, pars).QueryRows(&item)
|
|
|
+ err = o.Raw(sql, pars...).Find(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetRelationChartListByCondition(condition string, pars []interface{}, startSize, pageSize int) (item []*ChartInfoView, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT a.* FROM chart_info AS a
|
|
|
WHERE 1=1 `
|
|
|
if condition != "" {
|
|
@@ -877,18 +883,19 @@ func GetRelationChartListByCondition(condition string, pars []interface{}, start
|
|
|
}
|
|
|
//sql += " ORDER BY sort ASC,chart_info_id DESC LIMIT ?,? "
|
|
|
sql += " ORDER BY a.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 GetRelationChartListCountByCondition(condition string, pars []interface{}) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT COUNT(1) AS count FROM chart_info AS a
|
|
|
WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
|
}
|
|
|
- err = o.Raw(sql, pars).QueryRow(&count)
|
|
|
+ err = o.Raw(sql, pars...).Scan(&count).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -898,9 +905,9 @@ func GetChartInfoByIdList(chartInfoIdList []int) (items []*ChartInfo, err error)
|
|
|
if num <= 0 {
|
|
|
return
|
|
|
}
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT * FROM chart_info WHERE chart_info_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
- _, err = o.Raw(sql, chartInfoIdList).QueryRows(&items)
|
|
|
+ err = o.Raw(sql, chartInfoIdList).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -909,17 +916,17 @@ func GetChartInfoViewByIdList(chartInfoIdList []int) (items []*ChartInfoView, er
|
|
|
if num <= 0 {
|
|
|
return
|
|
|
}
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT * FROM chart_info WHERE chart_info_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
- _, err = o.Raw(sql, chartInfoIdList).QueryRows(&items)
|
|
|
+ err = o.Raw(sql, chartInfoIdList).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetMyChartClassifyByClassifyId 主键获取分类
|
|
|
func GetMyChartClassifyByClassifyId(classifyId int) (item *MyChartClassify, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := ` SELECT * FROM my_chart_classify WHERE my_chart_classify_id = ? `
|
|
|
- err = o.Raw(sql, classifyId).QueryRow(&item)
|
|
|
+ err = o.Raw(sql, classifyId).Find(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -956,7 +963,7 @@ type MyChartClassifyIdAndNum struct {
|
|
|
|
|
|
// GetMyChartClassifyIdAndNum 我的图表-获取分类ID及图表数
|
|
|
func GetMyChartClassifyIdAndNum(cond string, pars []interface{}) (items []*MyChartClassifyIdAndNum, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := fmt.Sprintf(`SELECT
|
|
|
a.my_chart_classify_id,
|
|
|
COUNT(1) AS chart_num
|
|
@@ -969,12 +976,12 @@ func GetMyChartClassifyIdAndNum(cond string, pars []interface{}) (items []*MyCha
|
|
|
1 = 1 %s
|
|
|
GROUP BY
|
|
|
a.my_chart_classify_id`, cond)
|
|
|
- _, err = o.Raw(sql, pars).QueryRows(&items)
|
|
|
+ err = o.Raw(sql, pars...).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetChartClassifyByIds(chartClassifyIds []string) (chart_classify_ids string, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := `SELECT GROUP_CONCAT(DISTINCT t.chart_classify_id) AS chart_classify_ids
|
|
|
FROM (
|
|
|
SELECT chart_classify_id
|
|
@@ -987,18 +994,18 @@ FROM (
|
|
|
WHERE parent_id IN (` + utils.GetOrmInReplace(len(chartClassifyIds)) + `)
|
|
|
)
|
|
|
) AS t;`
|
|
|
- err = o.Raw(sql, chartClassifyIds, chartClassifyIds, chartClassifyIds).QueryRow(&chart_classify_ids)
|
|
|
+ err = o.Raw(sql, chartClassifyIds, chartClassifyIds, chartClassifyIds).Scan(&chart_classify_ids).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetChartClassifyByIdsNoSubClassify(chartClassifyIds []string) (chart_classify_ids string, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := global.DbMap[utils.DbNameIndex]
|
|
|
sql := `SELECT GROUP_CONCAT(DISTINCT t.chart_classify_id) AS chart_classify_ids
|
|
|
FROM (
|
|
|
SELECT chart_classify_id
|
|
|
FROM chart_classify
|
|
|
WHERE chart_classify_id IN (` + utils.GetOrmInReplace(len(chartClassifyIds)) + `)
|
|
|
) AS t;`
|
|
|
- err = o.Raw(sql, chartClassifyIds).QueryRow(&chart_classify_ids)
|
|
|
+ err = o.Raw(sql, chartClassifyIds).Scan(&chart_classify_ids).Error
|
|
|
return
|
|
|
}
|