|
@@ -14,20 +14,10 @@ type ChartListResp struct {
|
|
|
}
|
|
|
|
|
|
func GetChartListByCondition(condition string, pars []interface{}, startSize, pageSize int) (item []*ChartInfoView, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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...).QueryRows(&item)
|
|
|
-
|
|
|
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 ?,? "
|
|
|
pars = append(pars, startSize)
|
|
|
pars = append(pars, pageSize)
|
|
@@ -36,13 +26,6 @@ func GetChartListByCondition(condition string, pars []interface{}, startSize, pa
|
|
|
}
|
|
|
|
|
|
func GetChartListCountByCondition(condition string, pars []interface{}) (count int, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //sql := ` SELECT COUNT(1) AS count FROM chart_info WHERE 1=1 `
|
|
|
- //if condition != "" {
|
|
|
- // sql += condition
|
|
|
- //}
|
|
|
- //err = o.Raw(sql, pars).QueryRow(&count)
|
|
|
-
|
|
|
sql := ` SELECT COUNT(1) AS count FROM chart_info WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
@@ -66,18 +49,11 @@ type MyChartClassify struct {
|
|
|
}
|
|
|
|
|
|
func AddMyChartClassify(item *MyChartClassify) (err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //_, err = o.Insert(item)
|
|
|
err = global.DmSQL["data"].Create(item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetMyChartClassifyAll(adminId int) (item []*MyChartClassify, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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)
|
|
|
-
|
|
|
sql := ` SELECT * FROM my_chart_classify WHERE 1=1 AND admin_id=? `
|
|
|
sql += " ORDER BY sort asc, my_chart_classify_id asc "
|
|
|
err = global.DmSQL["data"].Raw(sql, adminId).Find(&item).Error
|
|
@@ -85,11 +61,6 @@ func GetMyChartClassifyAll(adminId int) (item []*MyChartClassify, err error) {
|
|
|
}
|
|
|
|
|
|
func GetPublicChartClassifyAllExceptMy(adminId int) (item []*MyChartClassify, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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)
|
|
|
-
|
|
|
sql := ` SELECT * FROM my_chart_classify WHERE 1=1 AND is_public=1 AND admin_id !=?`
|
|
|
sql += " ORDER BY public_time asc"
|
|
|
err = global.DmSQL["data"].Raw(sql, adminId).Find(&item).Error
|
|
@@ -129,13 +100,6 @@ type MyChartClassifyAddReq struct {
|
|
|
}
|
|
|
|
|
|
func GetMyChartClassifyCountByCondition(condition string, pars []interface{}) (count int, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //sql := ` SELECT COUNT(1) AS count FROM my_chart_classify WHERE 1=1 `
|
|
|
- //if condition != "" {
|
|
|
- // sql += condition
|
|
|
- //}
|
|
|
- //err = o.Raw(sql, pars).QueryRow(&count)
|
|
|
-
|
|
|
sql := ` SELECT COUNT(1) AS count FROM my_chart_classify WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
@@ -145,29 +109,13 @@ func GetMyChartClassifyCountByCondition(condition string, pars []interface{}) (c
|
|
|
}
|
|
|
|
|
|
func GetMyChartClassifyById(adminId, myChartClassifyId int) (item *MyChartClassify, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //sql := ` SELECT * FROM my_chart_classify WHERE admin_id=? AND my_chart_classify_id=? `
|
|
|
- //err = o.Raw(sql, adminId, myChartClassifyId).QueryRow(&item)
|
|
|
-
|
|
|
sql := ` SELECT * FROM my_chart_classify WHERE admin_id=? AND my_chart_classify_id=? `
|
|
|
err = global.DmSQL["data"].Raw(sql, adminId, myChartClassifyId).First(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//// GetMyChartClassifyMastSort 获取MY ETA 分类中排序最大的值
|
|
|
-//func GetMyChartClassifyMastSort(adminId int) (sort int, err error) {
|
|
|
-// o := orm.NewOrmUsingDB("data")
|
|
|
-// sql := ` SELECT MAX(sort) sort FROM my_chart_classify WHERE admin_id=? `
|
|
|
-// err = o.Raw(sql, adminId).QueryRow(&sort)
|
|
|
-// return
|
|
|
-//}
|
|
|
-
|
|
|
// GetMyChartClassifyMinSort 获取MY ETA 分类中排序最小的值
|
|
|
func GetMyChartClassifyMinSort(adminId int) (sort int, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //sql := ` SELECT MIN(sort) sort FROM my_chart_classify WHERE admin_id=? `
|
|
|
- //err = o.Raw(sql, adminId).QueryRow(&sort)
|
|
|
-
|
|
|
sql := ` SELECT COALESCE(MIN(sort), 0) as sort FROM my_chart_classify WHERE admin_id=? `
|
|
|
err = global.DmSQL["data"].Raw(sql, adminId).Scan(&sort).Error
|
|
|
return
|
|
@@ -186,10 +134,6 @@ type MyChartClassifyMoveReq struct {
|
|
|
}
|
|
|
|
|
|
func ModifyMyChartClassify(myChartClassifyId int, myChartClassifyName string) (err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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()
|
|
|
-
|
|
|
sql := `UPDATE my_chart_classify SET my_chart_classify_name=?,modify_time=NOW() WHERE my_chart_classify_id=?`
|
|
|
err = global.DmSQL["data"].Exec(sql, myChartClassifyName, myChartClassifyId).Error
|
|
|
return
|
|
@@ -200,17 +144,6 @@ type MyChartClassifyDeleteReq struct {
|
|
|
}
|
|
|
|
|
|
func DeleteMyChartClassify(myChartClassifyId int) (err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //o.Begin()
|
|
|
- //
|
|
|
- //defer func() {
|
|
|
- // if err != nil {
|
|
|
- // o.Rollback()
|
|
|
- // } else {
|
|
|
- // o.Commit()
|
|
|
- // }
|
|
|
- //}()
|
|
|
-
|
|
|
sql := `DELETE FROM my_chart_classify WHERE my_chart_classify_id=?`
|
|
|
err = global.DmSQL["data"].Exec(sql, myChartClassifyId).Error
|
|
|
if err != nil {
|
|
@@ -272,9 +205,6 @@ type MyChartView struct {
|
|
|
}
|
|
|
|
|
|
func AddMyChart(item *MyChart) (lastId int64, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //lastId, err = o.Insert(item)
|
|
|
-
|
|
|
err = global.DmSQL["data"].Create(item).Error
|
|
|
return
|
|
|
}
|
|
@@ -290,18 +220,11 @@ type MyChartClassifyMapping struct {
|
|
|
}
|
|
|
|
|
|
func AddMyChartClassifyMapping(item *MyChartClassifyMapping) (lastId int64, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //lastId, err = o.Insert(item)
|
|
|
-
|
|
|
err = global.DmSQL["data"].Create(item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetMyChartClassifyMapping(adminId, myChartId, myChartClassifyId int) (item *MyChartClassifyMapping, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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)
|
|
|
-
|
|
|
sql := `SELECT * FROM my_chart_classify_mapping WHERE admin_id=? AND my_chart_id=? AND my_chart_classify_id=? `
|
|
|
err = global.DmSQL["data"].Raw(sql, adminId, myChartId, myChartClassifyId).First(&item).Error
|
|
|
return
|
|
@@ -313,7 +236,6 @@ type MyChartDeleteReq struct {
|
|
|
}
|
|
|
|
|
|
func DeleteMyChart(myChartId, myChartClassifyId int) (isDelMyChart bool, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
if myChartClassifyId > 0 {
|
|
|
sql := `DELETE FROM my_chart_classify_mapping WHERE my_chart_id=? AND my_chart_classify_id=? `
|
|
|
err = global.DmSQL["data"].Exec(sql, myChartId, myChartClassifyId).Error
|
|
@@ -385,25 +307,7 @@ type MyChartListResp struct {
|
|
|
}
|
|
|
|
|
|
func GetMyChartListByCondition(condition string, pars []interface{}, startSize, pageSize int) (item []*MyChartList, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //
|
|
|
- //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:"分类名称,多个用英文逗号分割"`
|
|
|
- ////MyChartClassifyId string `description:"分类id,多个用英文逗号分割"`
|
|
|
- //sql := ` SELECT * FROM ( SELECT ` + field + ` 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
|
|
|
- // INNER JOIN my_chart_classify AS d ON c.my_chart_classify_id=d.my_chart_classify_id
|
|
|
- // WHERE 1=1 `
|
|
|
- //if condition != "" {
|
|
|
- // sql += condition
|
|
|
- //}
|
|
|
- //sql += " GROUP BY a.chart_info_id) AS f ORDER BY sort ASC,c_ctime desc LIMIT ?,? "
|
|
|
- //_, err = o.Raw(sql, pars...).QueryRows(&item)
|
|
|
-
|
|
|
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:"分类名称,多个用英文逗号分割"`
|
|
|
- //MyChartClassifyId string `description:"分类id,多个用英文逗号分割"`
|
|
|
sql := ` SELECT * FROM ( SELECT ` + field + ` 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
|
|
@@ -421,18 +325,6 @@ func GetMyChartListByCondition(condition string, pars []interface{}, startSize,
|
|
|
}
|
|
|
|
|
|
func GetMyChartListCountByCondition(condition string, pars []interface{}) (count int, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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
|
|
|
- // INNER JOIN my_chart_classify AS d ON c.my_chart_classify_id=d.my_chart_classify_id
|
|
|
- // WHERE 1=1`
|
|
|
- //if condition != "" {
|
|
|
- // sql += condition
|
|
|
- //}
|
|
|
- //sql1 := ` SELECT COUNT(1) AS count FROM (` + sql + ` GROUP BY a.chart_info_id ) d`
|
|
|
- //err = o.Raw(sql1, pars).QueryRow(&count)
|
|
|
-
|
|
|
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
|
|
@@ -447,10 +339,6 @@ func GetMyChartListCountByCondition(condition string, pars []interface{}) (count
|
|
|
}
|
|
|
|
|
|
func GetMyChartMaxSort(adminId, myChartClassifyId int) (count int, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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)
|
|
|
-
|
|
|
sql := ` SELECT COUNT(1) AS count FROM my_chart_classify_mapping WHERE 1=1 AND admin_id=? AND my_chart_classify_id=? `
|
|
|
err = global.DmSQL["data"].Raw(sql, adminId, myChartClassifyId).Scan(&count).Error
|
|
|
return
|
|
@@ -464,10 +352,6 @@ type MoveMyChartReq struct {
|
|
|
}
|
|
|
|
|
|
func MyChartMove(sort float64, adminId int, myChartId, myChartClassifyId int) (err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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()
|
|
|
-
|
|
|
sql := ` UPDATE my_chart_classify_mapping SET sort = ?,modify_time=NOW() WHERE admin_id=? AND my_chart_id=? AND my_chart_classify_id=? `
|
|
|
err = global.DmSQL["data"].Exec(sql, sort, adminId, myChartId, myChartClassifyId).Error
|
|
|
return
|
|
@@ -475,12 +359,6 @@ func MyChartMove(sort float64, adminId int, myChartId, myChartClassifyId int) (e
|
|
|
|
|
|
// UpdateMyChartSortByClassifyId 根据分类id更新排序
|
|
|
func UpdateMyChartSortByClassifyId(myChartClassifyId, nowSort int, prevMyChartClassifyMappingId int, updateSort string) (err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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()
|
|
|
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=? )) `
|
|
@@ -489,34 +367,11 @@ func UpdateMyChartSortByClassifyId(myChartClassifyId, nowSort int, prevMyChartCl
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//func GetMyChartMinSortByAdminId(adminId int) (item *MyChart, err error) {
|
|
|
-// o := orm.NewOrmUsingDB("data")
|
|
|
-// sql := ` SELECT * FROM my_chart WHERE admin_id=? ORDER BY sort ASC LIMIT 1`
|
|
|
-// err = o.Raw(sql, adminId).QueryRow(&item)
|
|
|
-// return
|
|
|
-//}
|
|
|
-
|
|
|
type ChartRecommendListResp struct {
|
|
|
List []*ChartInfoView
|
|
|
}
|
|
|
|
|
|
func GetChartClassify(chartClassifyId int) (chart_classify_id string, err error) {
|
|
|
- // o := orm.NewOrmUsingDB("data")
|
|
|
- // 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=?
|
|
|
- // UNION ALL
|
|
|
- // SELECT a.chart_classify_id FROM chart_classify AS a
|
|
|
- // WHERE a.parent_id=? UNION ALL
|
|
|
- // SELECT
|
|
|
- // chart_classify_id
|
|
|
- // FROM
|
|
|
- // chart_classify
|
|
|
- //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)
|
|
|
-
|
|
|
sql := `SELECT LISTAGG(t.chart_classify_id, ',') WITHIN GROUP (ORDER BY t.chart_classify_id) AS chart_classify_id FROM (
|
|
|
SELECT a.chart_classify_id FROM chart_classify AS a
|
|
|
WHERE a.chart_classify_id=?
|
|
@@ -535,15 +390,6 @@ func GetChartClassify(chartClassifyId int) (chart_classify_id string, err error)
|
|
|
}
|
|
|
|
|
|
func GetRecommendChartListByCondition(condition string, pars []interface{}, startSize, pageSize int) (item []*ChartInfoView, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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...).QueryRows(&item)
|
|
|
-
|
|
|
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 != "" {
|
|
@@ -558,18 +404,6 @@ func GetRecommendChartListByCondition(condition string, pars []interface{}, star
|
|
|
}
|
|
|
|
|
|
func GetMyChartListByAdminId(adminId int) (item []*MyChartView, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- ////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
|
|
|
- // LEFT JOIN my_chart_classify_mapping AS b ON a.my_chart_id=b.my_chart_id AND a.admin_id=b.admin_id
|
|
|
- // 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)
|
|
|
-
|
|
|
- //sql := ` SELECT * FROM my_chart WHERE 1=1 AND admin_id=? `
|
|
|
-
|
|
|
sql := ` SELECT
|
|
|
a.my_chart_id,a.chart_info_id,a.source,a.admin_id,a.create_time,a.modify_time,LISTAGG(c.my_chart_classify_id, ',') WITHIN GROUP (ORDER BY c.my_chart_classify_id) AS my_chart_classify_id
|
|
|
FROM my_chart AS a
|
|
@@ -589,20 +423,6 @@ func GetMyChartListByAdminId(adminId int) (item []*MyChartView, err error) {
|
|
|
}
|
|
|
|
|
|
func GetMyChartSearchByCondition(condition string, pars []interface{}) (item []*MyChartList, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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
|
|
|
- // INNER JOIN my_chart_classify_mapping AS c ON a.my_chart_id=c.my_chart_id
|
|
|
- // INNER JOIN my_chart_classify AS d ON c.my_chart_classify_id=d.my_chart_classify_id
|
|
|
- // WHERE 1=1 `
|
|
|
- //
|
|
|
- //if condition != "" {
|
|
|
- // sql += condition
|
|
|
- //}
|
|
|
- //sql += " GROUP BY a.chart_info_id ORDER BY c.sort DESC "
|
|
|
- //_, err = o.Raw(sql, pars).QueryRows(&item)
|
|
|
-
|
|
|
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
|
|
@@ -630,12 +450,6 @@ type MyChartEditReq struct {
|
|
|
}
|
|
|
|
|
|
func GetMyChartClassifyMappingCount(adminId, myChartId, myChartClassifyId int) (count int, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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)
|
|
|
-
|
|
|
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=? `
|
|
@@ -644,11 +458,6 @@ func GetMyChartClassifyMappingCount(adminId, myChartId, myChartClassifyId int) (
|
|
|
}
|
|
|
|
|
|
func DeleteMyChartClassifyMapping(adminId, myChartId, myChartClassifyId int) (err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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()
|
|
|
-
|
|
|
sql := ` DELETE FROM my_chart_classify_mapping
|
|
|
WHERE admin_id=? AND my_chart_id=? AND my_chart_classify_id=? `
|
|
|
err = global.DmSQL["data"].Exec(sql, adminId, myChartId, myChartClassifyId).Error
|
|
@@ -656,15 +465,6 @@ func DeleteMyChartClassifyMapping(adminId, myChartId, myChartClassifyId int) (er
|
|
|
}
|
|
|
|
|
|
func GetMyChartSort(adminId, myChartClassifyId, sort int) (item *MyChartClassifyMapping, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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)
|
|
|
-
|
|
|
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 `
|
|
@@ -676,19 +476,6 @@ func GetMyChartSort(adminId, myChartClassifyId, sort int) (item *MyChartClassify
|
|
|
}
|
|
|
|
|
|
func GetMyChartByCondition(condition string, pars []interface{}) (item []*MyChartView, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- ////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
|
|
|
- // 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
|
|
|
- // `
|
|
|
- //if condition != "" {
|
|
|
- // sql += condition
|
|
|
- //}
|
|
|
- //sql += ` GROUP BY a.chart_info_id `
|
|
|
- //_, err = o.Raw(sql, pars).QueryRows(&item)
|
|
|
-
|
|
|
sql := `SELECT a.my_chart_id,a.chart_info_id,a.source,a.admin_id,a.create_time,a.modify_time,LISTAGG(c.my_chart_classify_id, ',') WITHIN GROUP (ORDER BY c.my_chart_classify_id) 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
|
|
@@ -711,13 +498,6 @@ func GetMyChartByCondition(condition string, pars []interface{}) (item []*MyChar
|
|
|
}
|
|
|
|
|
|
func GetMyChartDetailByCondition(condition string, pars []interface{}) (item *MyChartView, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //sql := ` SELECT * FROM my_chart WHERE 1=1 `
|
|
|
- //if condition != "" {
|
|
|
- // sql += condition
|
|
|
- //}
|
|
|
- //err = o.Raw(sql, pars).QueryRow(&item)
|
|
|
-
|
|
|
sql := ` SELECT * FROM my_chart WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
@@ -727,19 +507,6 @@ func GetMyChartDetailByCondition(condition string, pars []interface{}) (item *My
|
|
|
}
|
|
|
|
|
|
func MoveMyChartClassify(adminId, myChartId int, myChartClassifyId []int) (err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //to, err := o.Begin()
|
|
|
- //if err != nil {
|
|
|
- // return
|
|
|
- //}
|
|
|
- //defer func() {
|
|
|
- // if err != nil {
|
|
|
- // _ = to.Rollback()
|
|
|
- // } else {
|
|
|
- // _ = to.Commit()
|
|
|
- // }
|
|
|
- //}()
|
|
|
-
|
|
|
to := global.DmSQL["data"].Begin()
|
|
|
|
|
|
defer func() {
|
|
@@ -756,12 +523,6 @@ 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)
|
|
|
- //if err != nil {
|
|
|
- // return
|
|
|
- //}
|
|
|
-
|
|
|
sql := `SELECT * FROM my_chart_classify_mapping WHERE admin_id=? AND my_chart_id=?`
|
|
|
err = to.Raw(sql, adminId, myChartId).Find(&mappingList).Error
|
|
|
if err != nil {
|
|
@@ -770,12 +531,6 @@ func MoveMyChartClassify(adminId, myChartId int, myChartClassifyId []int) (err e
|
|
|
|
|
|
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()
|
|
|
- //if err != nil {
|
|
|
- // return
|
|
|
- //}
|
|
|
-
|
|
|
sql := ` DELETE FROM my_chart_classify_mapping WHERE my_chart_classify_mapping_id=? `
|
|
|
err = to.Exec(sql, v.MyChartClassifyMappingId).Error
|
|
|
if err != nil {
|
|
@@ -783,12 +538,6 @@ func MoveMyChartClassify(adminId, myChartId int, myChartClassifyId []int) (err e
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- //sql := `DELETE FROM my_chart_classify_mapping WHERE admin_id=? AND my_chart_id=? `
|
|
|
- //_, err = to.Raw(sql, adminId, myChartId).Exec()
|
|
|
- //if err != nil {
|
|
|
- // return err
|
|
|
- //}
|
|
|
- //step := float64(65536)
|
|
|
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=? `
|
|
@@ -822,18 +571,12 @@ 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...)
|
|
|
err = global.DmSQL["data"].Select(cols).Updates(myChartClassify).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetFirstMyChartClassifyByAdminId 获取当前账号下,排序第一条的分类数据
|
|
|
func GetFirstMyChartClassifyByAdminId(adminId int) (item *MyChartClassify, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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)
|
|
|
-
|
|
|
sql := ` SELECT * FROM my_chart_classify WHERE admin_id=? order by sort asc,my_chart_classify_id asc limit 1`
|
|
|
err = global.DmSQL["data"].Raw(sql, adminId).First(&item).Error
|
|
|
return
|
|
@@ -841,13 +584,6 @@ func GetFirstMyChartClassifyByAdminId(adminId int) (item *MyChartClassify, err e
|
|
|
|
|
|
// UpdateMyChartClassifySortByClassifyId 根据分类id更新排序
|
|
|
func UpdateMyChartClassifySortByClassifyId(adminId, classifyId, nowSort int, updateSort string) (err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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()
|
|
|
-
|
|
|
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) + `)`
|
|
@@ -869,10 +605,6 @@ type CopyChartClassifyReq struct {
|
|
|
|
|
|
// GetPublicMyChartClassifyById 根据分类ID获取公开分类
|
|
|
func GetPublicMyChartClassifyById(myChartClassifyId int) (item *MyChartClassify, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //sql := ` SELECT * FROM my_chart_classify WHERE is_public=1 AND my_chart_classify_id=? `
|
|
|
- //err = o.Raw(sql, myChartClassifyId).QueryRow(&item)
|
|
|
-
|
|
|
sql := ` SELECT * FROM my_chart_classify WHERE is_public=1 AND my_chart_classify_id=? `
|
|
|
err = global.DmSQL["data"].Raw(sql, myChartClassifyId).First(&item).Error
|
|
|
return
|
|
@@ -880,19 +612,6 @@ func GetPublicMyChartClassifyById(myChartClassifyId int) (item *MyChartClassify,
|
|
|
|
|
|
// 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
|
|
|
- //}
|
|
|
- //defer func() {
|
|
|
- // if err != nil {
|
|
|
- // _ = to.Rollback()
|
|
|
- // } else {
|
|
|
- // _ = to.Commit()
|
|
|
- // }
|
|
|
- //}()
|
|
|
-
|
|
|
to := global.DmSQL["data"].Begin()
|
|
|
|
|
|
defer func() {
|
|
@@ -940,10 +659,6 @@ WHERE b.my_chart_classify_id=?`
|
|
|
ModifyTime: time.Now(),
|
|
|
Sort: minSort - 1,
|
|
|
}
|
|
|
- //newMyChartClassifyId, err := to.Insert(newMyChartClassify)
|
|
|
- //if err != nil {
|
|
|
- // return
|
|
|
- //}
|
|
|
err = to.Create(newMyChartClassify).Error
|
|
|
newMappingList := make([]*MyChartClassifyMapping, 0)
|
|
|
|
|
@@ -956,12 +671,6 @@ WHERE b.my_chart_classify_id=?`
|
|
|
CreateTime: time.Now(),
|
|
|
ModifyTime: time.Now(),
|
|
|
}
|
|
|
- //tmpMyChartId, tmpErr := to.Insert(tmpMyChart)
|
|
|
- //if tmpErr != nil {
|
|
|
- // err = tmpErr
|
|
|
- //}
|
|
|
- //tmpMyChart.MyChartId = int(tmpMyChartId)
|
|
|
-
|
|
|
tmpErr := to.Create(tmpMyChart)
|
|
|
if tmpErr != nil {
|
|
|
err = tmpErr.Error
|
|
@@ -1001,12 +710,6 @@ type ModifyChartClassifyCompanyPublicReq struct {
|
|
|
|
|
|
// GetCompanyPublicClassifyList 获取用户可见的分类列表
|
|
|
func GetCompanyPublicClassifyList(condition string, pars []interface{}) (item []*MyChartClassify, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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)
|
|
|
-
|
|
|
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"
|
|
@@ -1016,19 +719,6 @@ func GetCompanyPublicClassifyList(condition string, pars []interface{}) (item []
|
|
|
|
|
|
// GetMyChartClassifyList 获取我的图表关联的分类列表数据
|
|
|
func GetMyChartClassifyList(myChartClassifyId int) (mappingList []*MyChartClassifyMapping, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- ////o.Begin()
|
|
|
- ////
|
|
|
- ////defer func() {
|
|
|
- //// if err != nil {
|
|
|
- //// o.Rollback()
|
|
|
- //// } else {
|
|
|
- //// o.Commit()
|
|
|
- //// }
|
|
|
- ////}()
|
|
|
- //sql := `SELECT * FROM my_chart_classify_mapping WHERE my_chart_id=?`
|
|
|
- //_, err = o.Raw(sql, myChartClassifyId).QueryRows(&mappingList)
|
|
|
-
|
|
|
sql := `SELECT * FROM my_chart_classify_mapping WHERE my_chart_id=?`
|
|
|
err = global.DmSQL["data"].Raw(sql, myChartClassifyId).Find(&mappingList).Error
|
|
|
return
|
|
@@ -1036,16 +726,6 @@ func GetMyChartClassifyList(myChartClassifyId int) (mappingList []*MyChartClassi
|
|
|
|
|
|
// AddMyChartToMyChartClassify 添加我的图表至我的分类
|
|
|
func AddMyChartToMyChartClassify(adminId, myChartId int, myChartClassifyId []int) (err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //o.Begin()
|
|
|
-
|
|
|
- //defer func() {
|
|
|
- // if err != nil {
|
|
|
- // o.Rollback()
|
|
|
- // } else {
|
|
|
- // o.Commit()
|
|
|
- // }
|
|
|
- //}()
|
|
|
//需要添加的分类id 集合map
|
|
|
classifyIdMap := make(map[int]int)
|
|
|
for _, v := range myChartClassifyId {
|
|
@@ -1054,12 +734,6 @@ 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)
|
|
|
- //if err != nil {
|
|
|
- // return
|
|
|
- //}
|
|
|
-
|
|
|
sql := `SELECT * FROM my_chart_classify_mapping WHERE admin_id=? AND my_chart_id=?`
|
|
|
err = global.DmSQL["data"].Raw(sql, adminId, myChartId).Find(&mappingList).Error
|
|
|
if err != nil {
|
|
@@ -1075,12 +749,6 @@ func AddMyChartToMyChartClassify(adminId, myChartId int, myChartClassifyId []int
|
|
|
step := float64(65536)
|
|
|
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)
|
|
|
- //if err != nil {
|
|
|
- // return
|
|
|
- //}
|
|
|
-
|
|
|
sql := ` SELECT COUNT(1) AS count FROM my_chart_classify_mapping WHERE my_chart_id=? AND my_chart_classify_id=? `
|
|
|
err = global.DmSQL["data"].Raw(sql, myChartId, v).Scan(&count).Error
|
|
|
if err != nil {
|
|
@@ -1092,18 +760,6 @@ func AddMyChartToMyChartClassify(adminId, myChartId int, myChartClassifyId []int
|
|
|
return err
|
|
|
}
|
|
|
sort := (float64(total) + 1) * step
|
|
|
- //sql = ` INSERT INTO my_chart_classify_mapping (
|
|
|
- // admin_id,
|
|
|
- // my_chart_id,
|
|
|
- // my_chart_classify_id,
|
|
|
- // create_time,
|
|
|
- // modify_time,
|
|
|
- // sort )VALUES (?,?,?,NOW(),NOW(),?) `
|
|
|
- //_, err = o.Raw(sql, adminId, myChartId, v, sort).Exec()
|
|
|
- //if err != nil {
|
|
|
- // return err
|
|
|
- //}
|
|
|
-
|
|
|
sql = ` INSERT INTO my_chart_classify_mapping (
|
|
|
admin_id,
|
|
|
my_chart_id,
|
|
@@ -1123,32 +779,6 @@ 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")
|
|
|
- //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
|
|
|
- // INNER JOIN my_chart_classify_mapping AS c ON a.my_chart_id=c.my_chart_id
|
|
|
- // INNER JOIN my_chart_classify AS d ON c.my_chart_classify_id=d.my_chart_classify_id
|
|
|
- // WHERE 1=1 `
|
|
|
- //
|
|
|
- //if condition != "" {
|
|
|
- // sql += condition
|
|
|
- //}
|
|
|
- //sql += " GROUP BY a.chart_info_id,a.admin_id ORDER BY c.sort DESC "
|
|
|
- //_, err = o.Raw(sql, pars).QueryRows(&item)
|
|
|
-
|
|
|
- //sql := ` SELECT a.admin_id,a.my_chart_id,c.sort,b.*,LISTAGG(DISTINCT d.my_chart_classify_name, ',') WITHIN GROUP (ORDER BY d.my_chart_classify_name) AS my_chart_classify_name,LISTAGG(d.my_chart_classify_id, ',') WITHIN GROUP (ORDER BY 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
|
|
|
- // INNER JOIN my_chart_classify_mapping AS c ON a.my_chart_id=c.my_chart_id
|
|
|
- // INNER JOIN my_chart_classify AS d ON c.my_chart_classify_id=d.my_chart_classify_id
|
|
|
- // WHERE 1=1 `
|
|
|
- //
|
|
|
- //if condition != "" {
|
|
|
- // sql += condition
|
|
|
- //}
|
|
|
- //sql += " GROUP BY a.chart_info_id,a.admin_id ORDER BY c.sort DESC "
|
|
|
-
|
|
|
sql := `SELECT a.admin_id,a.my_chart_id,c.sort,b.chart_info_id, b.chart_name, b.unique_code, b.chart_classify_id, b.sys_user_id, b.sys_user_real_name, 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.sort, b.edb_end_date, b.x_min, b.x_max, b.left_min, b.left_max, b.right_min, b.right_max, b.right2_min, b.right2_max, b.min_max_save, b.chart_name_en, b.disabled, b.source, b.start_year, b.chart_theme_id, b.unit, b.unit_en, b.is_join_permission, b.forum_chart_info_id, b.chart_alias, b.date_type_num,LISTAGG(DISTINCT d.my_chart_classify_name, ',') WITHIN GROUP (ORDER BY d.my_chart_classify_name) AS my_chart_classify_name,LISTAGG(d.my_chart_classify_id, ',') WITHIN GROUP (ORDER BY 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
|
|
@@ -1165,16 +795,6 @@ WHERE 1=1 `
|
|
|
}
|
|
|
|
|
|
func GetRelationChartListByCondition(condition string, pars []interface{}, startSize, pageSize int) (item []*ChartInfoView, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //sql := ` SELECT a.* FROM chart_info AS a
|
|
|
- //WHERE 1=1 `
|
|
|
- //if condition != "" {
|
|
|
- // sql += condition
|
|
|
- //}
|
|
|
- ////sql += " ORDER BY sort ASC,chart_info_id DESC LIMIT ?,? "
|
|
|
- //sql += " ORDER BY a.create_time DESC LIMIT ?,? "
|
|
|
- //_, err = o.Raw(sql, pars...).QueryRows(&item)
|
|
|
-
|
|
|
sql := ` SELECT a.* FROM chart_info AS a
|
|
|
WHERE 1=1 `
|
|
|
if condition != "" {
|
|
@@ -1190,14 +810,6 @@ func GetRelationChartListByCondition(condition string, pars []interface{}, start
|
|
|
}
|
|
|
|
|
|
func GetRelationChartListCountByCondition(condition string, pars []interface{}) (count int, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //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)
|
|
|
-
|
|
|
sql := ` SELECT COUNT(1) AS count FROM chart_info AS a
|
|
|
WHERE 1=1 `
|
|
|
if condition != "" {
|
|
@@ -1213,10 +825,6 @@ func GetChartInfoByIdList(chartInfoIdList []int) (items []*ChartInfo, err error)
|
|
|
if num <= 0 {
|
|
|
return
|
|
|
}
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //sql := ` SELECT * FROM chart_info WHERE chart_info_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
- //_, err = o.Raw(sql, chartInfoIdList).QueryRows(&items)
|
|
|
-
|
|
|
sql := ` SELECT * FROM chart_info WHERE chart_info_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
err = global.DmSQL["data"].Raw(sql, chartInfoIdList).Find(&items).Error
|
|
|
return
|
|
@@ -1227,10 +835,6 @@ func GetChartInfoViewByIdList(chartInfoIdList []int) (items []*ChartInfoView, er
|
|
|
if num <= 0 {
|
|
|
return
|
|
|
}
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //sql := ` SELECT * FROM chart_info WHERE chart_info_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
- //_, err = o.Raw(sql, chartInfoIdList).QueryRows(&items)
|
|
|
-
|
|
|
sql := ` SELECT * FROM chart_info WHERE chart_info_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
err = global.DmSQL["data"].Raw(sql, chartInfoIdList).Find(&items).Error
|
|
|
return
|
|
@@ -1238,10 +842,6 @@ func GetChartInfoViewByIdList(chartInfoIdList []int) (items []*ChartInfoView, er
|
|
|
|
|
|
// GetMyChartClassifyByClassifyId 主键获取分类
|
|
|
func GetMyChartClassifyByClassifyId(classifyId int) (item *MyChartClassify, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //sql := ` SELECT * FROM my_chart_classify WHERE my_chart_classify_id = ? `
|
|
|
- //err = o.Raw(sql, classifyId).QueryRow(&item)
|
|
|
-
|
|
|
sql := ` SELECT * FROM my_chart_classify WHERE my_chart_classify_id = ? `
|
|
|
err = global.DmSQL["data"].Raw(sql, classifyId).First(&item).Error
|
|
|
return
|
|
@@ -1280,21 +880,6 @@ type MyChartClassifyIdAndNum struct {
|
|
|
|
|
|
// GetMyChartClassifyIdAndNum 我的图表-获取分类ID及图表数
|
|
|
func GetMyChartClassifyIdAndNum(cond string, pars []interface{}) (items []*MyChartClassifyIdAndNum, err error) {
|
|
|
- //o := orm.NewOrmUsingDB("data")
|
|
|
- //sql := fmt.Sprintf(`SELECT
|
|
|
- // a.my_chart_classify_id,
|
|
|
- // COUNT(1) AS chart_num
|
|
|
- // FROM
|
|
|
- // my_chart_classify AS a
|
|
|
- // INNER JOIN my_chart_classify_mapping AS b ON a.my_chart_classify_id = b.my_chart_classify_id
|
|
|
- // INNER JOIN my_chart AS c ON b.my_chart_id = c.my_chart_id
|
|
|
- // INNER JOIN chart_info AS d ON c.chart_info_id = d.chart_info_id
|
|
|
- // WHERE
|
|
|
- // 1 = 1 %s
|
|
|
- // GROUP BY
|
|
|
- // a.my_chart_classify_id`, cond)
|
|
|
- //_, err = o.Raw(sql, pars).QueryRows(&items)
|
|
|
-
|
|
|
sql := fmt.Sprintf(`SELECT
|
|
|
a.my_chart_classify_id,
|
|
|
COUNT(1) AS chart_num
|