123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350 |
- package models
- import (
- "eta/eta_forum_hub/utils"
- "fmt"
- "github.com/beego/beego/v2/client/orm"
- "time"
- )
- type ChartClassify struct {
- ChartClassifyId int `orm:"column(chart_classify_id);pk"`
- ChartClassifyName string `description:"分类名称"`
- ParentId int `description:"父级id"`
- HasData int `description:"是否含有指标数据"`
- CreateTime time.Time `description:"创建时间"`
- ModifyTime time.Time `description:"修改时间"`
- SysUserId int `description:"创建人id"`
- SysUserRealName string `description:"创建人姓名"`
- Level int `description:"层级"`
- UniqueCode string `description:"唯一编码"`
- Sort int `description:"排序字段,越小越靠前,默认值:10"`
- Source int `description:"1:ETA图库;2:商品价格曲线"`
- IsJoinPermission int `description:"是否加入权限管控,0:不加入;1:加入;默认:0"`
- }
- func AddChartClassify(item *ChartClassify) (lastId int64, err error) {
- o := orm.NewOrm()
- lastId, err = o.Insert(item)
- return
- }
- type AddChartClassifyReq struct {
- ChartClassifyName string `description:"分类名称"`
- ParentId int `description:"父级id,第一级传0"`
- Level int `description:"层级,第一级传0,其余传上一级的层级"`
- }
- func GetChartClassifyCount(chartClassifyName string, parentId, source int) (count int, err error) {
- o := orm.NewOrm()
- sql := `SELECT COUNT(1) AS count FROM chart_classify WHERE parent_id=? AND source = ? AND chart_classify_name=? `
- err = o.Raw(sql, parentId, source, chartClassifyName).QueryRow(&count)
- return
- }
- type EditChartClassifyReq struct {
- ChartClassifyName string `description:"分类名称"`
- ChartClassifyId int `description:"分类id"`
- }
- func GetChartClassifyById(classifyId int) (item *ChartClassify, err error) {
- o := orm.NewOrm()
- sql := `SELECT * FROM chart_classify WHERE chart_classify_id=? `
- err = o.Raw(sql, classifyId).QueryRow(&item)
- return
- }
- func GetChartClassifyCountById(classifyId int) (count int, err error) {
- o := orm.NewOrm()
- sql := `SELECT count(1) AS count FROM chart_classify WHERE chart_classify_id=? `
- err = o.Raw(sql, classifyId).QueryRow(&count)
- return
- }
- func EditChartClassify(classifyId, source int, chartClassifyName string) (err error) {
- o := orm.NewOrm()
- sql := `UPDATE chart_classify SET chart_classify_name=?,modify_time=NOW() WHERE chart_classify_id=? AND source = ? `
- _, err = o.Raw(sql, chartClassifyName, classifyId, source).Exec()
- return
- }
- type DeleteChartClassifyReq struct {
- ChartClassifyId int `description:"分类id"`
- ChartInfoId int `description:"指标id"`
- }
- func GetChartInfoCountByClassifyId(classifyId int) (count int, err error) {
- o := orm.NewOrm()
- sql := ` SELECT COUNT(1) AS count FROM chart_info AS a
- WHERE a.chart_classify_id IN(
- SELECT t.chart_classify_id FROM
- (
- SELECT rd.*
- FROM (SELECT * FROM chart_classify WHERE parent_id IS NOT NULL) rd,
- (SELECT @pid := ?) pd
- WHERE FIND_IN_SET(parent_id, @pid) > 0
- AND @pid := CONCAT(@pid, ',', chart_classify_id)
- UNION SELECT * FROM chart_classify WHERE chart_classify_id = @pid
- )AS t
- ) `
- err = o.Raw(sql, classifyId).QueryRow(&count)
- return
- }
- func DeleteChartClassify(classifyId int) (err error) {
- o := orm.NewOrm()
- sql := ` DELETE FROM chart_classify
- WHERE chart_classify_id IN(
- SELECT t.chart_classify_id FROM
- (
- SELECT rd.*
- FROM (SELECT * FROM chart_classify WHERE parent_id IS NOT NULL) rd,
- (SELECT @pid := ?) pd
- WHERE FIND_IN_SET(parent_id, @pid) > 0
- AND @pid := CONCAT(@pid, ',', chart_classify_id)
- UNION SELECT * FROM chart_classify WHERE chart_classify_id = @pid
- )AS t
- ) `
- _, err = o.Raw(sql, classifyId).Exec()
- return
- }
- // GetChartClassifyByParentId
- // @param source int 1:ETA图库;2:商品价格曲线;3:相关性图表
- func GetChartClassifyByParentId(parentId, source int) (items []*ChartClassifyItems, err error) {
- o := orm.NewOrm()
- sql := ` SELECT * FROM chart_classify WHERE parent_id=? AND source = ? order by sort asc,chart_classify_id asc`
- _, err = o.Raw(sql, parentId, source).QueryRows(&items)
- return
- }
- // GetChartClassifyAll
- // @param source int 1:ETA图库;2:商品价格曲线;3:相关性图表
- func GetChartClassifyAll(source int) (items []*ChartClassifyItems, err error) {
- o := orm.NewOrm()
- sql := ` SELECT * FROM chart_classify WHERE parent_id<>0 AND source = ? order by sort asc,chart_classify_id asc`
- _, err = o.Raw(sql, source).QueryRows(&items)
- return
- }
- type ChartClassifyItems struct {
- ChartClassifyId int `description:"分类id"`
- ChartInfoId int `description:"指标id"`
- ChartClassifyName string
- ChartClassifyNameEn string
- ParentId int
- Level int `description:"层级"`
- Sort int `description:"排序字段,越小越靠前,默认值:10"`
- UniqueCode string `description:"唯一编码"`
- Source int `description:"来源id"`
- SourceName string `description:"来源名称"`
- SysUserId int `description:"创建人id"`
- SysUserRealName string `description:"创建人姓名"`
- DateType int `description:"日期类型:1:00年至今,2:10年至今,3:15年至今,4:年初至今,5:自定义时间"`
- StartDate string `description:"自定义开始日期"`
- EndDate string `description:"自定义结束日期"`
- ChartType int `description:"生成样式:1:曲线图,2:季节性图"`
- Calendar string `description:"公历/农历"`
- SeasonStartDate string `description:"季节性图开始日期"`
- SeasonEndDate string `description:"季节性图开始日期"`
- Children []*ChartClassifyItems
- Button ChartClassifyItemsButton `description:"按钮权限"`
- IsJoinPermission int `description:"是否加入权限管控,0:不加入;1:加入;默认:0"`
- HaveOperaAuth bool `description:"是否有数据权限,默认:false"`
- }
- // ChartClassifyItemsButton 操作按钮
- type ChartClassifyItemsButton struct {
- AddButton bool `description:"是否可添加"`
- OpButton bool `description:"是否可编辑"`
- DeleteButton bool `description:"是否可删除"`
- MoveButton bool `description:"是否可移动"`
- }
- type ChartClassifyListResp struct {
- AllNodes []*ChartClassifyItems
- Language string `description:"指标的展示语言,CN:中文,EN:英文"`
- CanOpClassify bool `description:"是否允许操作分类"`
- }
- type ChartClassifyDeleteCheckResp struct {
- DeleteStatus int `description:"检测状态:0:默认值,如果为0,继续走其他校验,1:该分类下关联图表不可删除,2:确认删除当前目录及包含的子目录吗"`
- TipsMsg string `description:"提示信息"`
- }
- type ChartClassifyDeleteCheckReq struct {
- ChartClassifyId int `description:"分类id"`
- ChartInfoId int `description:"指标id"`
- }
- func GetChartClassifyCountByClassifyId(chartClassifyId int) (count int, err error) {
- o := orm.NewOrm()
- sql := ` SELECT COUNT(1) AS count FROM (
- SELECT rd.*
- FROM (SELECT * FROM chart_classify WHERE parent_id IS NOT NULL) rd,
- (SELECT @pid := ?) pd
- WHERE FIND_IN_SET(parent_id, @pid) > 0
- AND @pid := CONCAT(@pid, ',', chart_classify_id)
- UNION SELECT * FROM chart_classify WHERE chart_classify_id = @pid
- )AS t
- WHERE t.chart_classify_id<>? `
- err = o.Raw(sql, chartClassifyId, chartClassifyId).QueryRow(&count)
- return
- }
- func GetChartClassifyByCondition(condition string, pars []interface{}) (item *ChartClassify, err error) {
- o := orm.NewOrm()
- sql := ` SELECT * FROM chart_classify WHERE 1=1 `
- if condition != "" {
- sql += condition
- }
- err = o.Raw(sql, pars).QueryRow(&item)
- return
- }
- // MoveChartClassifyReq 移动图表分类请求参数
- type MoveChartClassifyReq struct {
- ClassifyId int `description:"分类id"`
- ParentClassifyId int `description:"父级分类id"`
- PrevClassifyId int `description:"上一个兄弟节点分类id"`
- NextClassifyId int `description:"下一个兄弟节点分类id"`
- }
- // GetFirstChartClassifyByParentId 获取当前父级图表分类下的排序第一条的数据
- func GetFirstChartClassifyByParentId(parentId int) (item *ChartClassify, err error) {
- o := orm.NewOrm()
- sql := ` SELECT * FROM chart_classify WHERE parent_id=? order by sort asc,chart_classify_id asc limit 1`
- err = o.Raw(sql, parentId).QueryRow(&item)
- return
- }
- // GetFirstChartClassifyByParentIdAndSource 获取当前父级图表分类下的排序第一条的数据
- func GetFirstChartClassifyByParentIdAndSource(parentId, source int) (item *ChartClassify, err error) {
- o := orm.NewOrm()
- sql := ` SELECT * FROM chart_classify WHERE parent_id=? and source = ? order by sort asc,chart_classify_id asc limit 1`
- err = o.Raw(sql, parentId, source).QueryRow(&item)
- return
- }
- // UpdateChartClassifySortByParentId 根据图表父类id更新排序
- func UpdateChartClassifySortByParentId(parentId, classifyId, nowSort int, updateSort string) (err error) {
- o := orm.NewOrm()
- sql := ` update chart_classify set sort = ` + updateSort + ` WHERE parent_id=? and sort > ? `
- if classifyId > 0 {
- sql += ` or ( chart_classify_id > ` + fmt.Sprint(classifyId) + ` and sort= ` + fmt.Sprint(nowSort) + `)`
- }
- _, err = o.Raw(sql, parentId, nowSort).Exec()
- return
- }
- // Update 更新图表分类基础信息
- func (chartClassify *ChartClassify) Update(cols []string) (err error) {
- o := orm.NewOrm()
- _, err = o.Update(chartClassify, cols...)
- return
- }
- // GetChartClassifyMaxSort 获取图表分类下最大的排序数
- func GetChartClassifyMaxSort(parentId, source int) (sort int, err error) {
- o := orm.NewOrm()
- sql := `SELECT Max(sort) AS sort FROM chart_classify WHERE parent_id=? AND source = ? `
- err = o.Raw(sql, parentId, source).QueryRow(&sort)
- return
- }
- type ChartClassifyView struct {
- ChartClassifyId int `orm:"column(chart_classify_id);pk"`
- ChartClassifyName string `description:"分类名称"`
- ParentId int `description:"父级id"`
- }
- func GetChartClassifyViewById(classifyId int) (item *ChartClassifyView, err error) {
- o := orm.NewOrm()
- sql := `SELECT * FROM chart_classify WHERE chart_classify_id=? `
- err = o.Raw(sql, classifyId).QueryRow(&item)
- return
- }
- func GetChartClassifyByParentIdFromETA(parentId int) (items []*ChartClassifyItems, err error) {
- o := orm.NewOrm()
- sql := ` SELECT * FROM chart_classify WHERE parent_id=? AND source = 1 order by sort asc,chart_classify_id asc`
- _, err = o.Raw(sql, parentId).QueryRows(&items)
- return
- }
- func GetChartClassifyAllFromETA() (items []*ChartClassifyItems, err error) {
- o := orm.NewOrm()
- sql := ` SELECT * FROM chart_classify WHERE parent_id<>0 AND source = 1 order by sort asc,chart_classify_id asc`
- _, err = o.Raw(sql).QueryRows(&items)
- return
- }
- func GetChartClassifyTwo(source int) (items []*ChartClassifyItems, err error) {
- o := orm.NewOrm()
- sql := ` SELECT * FROM chart_classify WHERE level=3 AND source = ? order by sort asc,chart_classify_id asc`
- _, err = o.Raw(sql, source).QueryRows(&items)
- return
- }
- func GetChartClassifyByLevel(level, source int) (items []*ChartClassifyItems, err error) {
- o := orm.NewOrm()
- sql := ` SELECT * FROM chart_classify WHERE level=? AND source = ? order by sort asc,chart_classify_id asc`
- _, err = o.Raw(sql, level, source).QueryRows(&items)
- return
- }
- func EditChartClassifySysUser(classifyId, sysUserId int, chartClassifyName string) (err error) {
- o := orm.NewOrm()
- sql := `UPDATE chart_classify SET sys_user_id=?,sys_user_real_name=?,modify_time=NOW() WHERE parent_id=? AND level=3 `
- _, err = o.Raw(sql, sysUserId, chartClassifyName, classifyId).Exec()
- return
- }
- func GetAllChartClassifyItemsBySource(source int) (items []*ChartClassifyItems, err error) {
- o := orm.NewOrm()
- sql := ` SELECT * FROM chart_classify WHERE source = ? order by sort ASC,chart_classify_id ASC`
- _, err = o.Raw(sql, source).QueryRows(&items)
- return
- }
- // GetChartClassifyByParentIdAndName 根据父级ID和名称获取分类
- func GetChartClassifyByParentIdAndName(parentId int, classifyName string, classifyId int) (item *ChartClassify, err error) {
- o := orm.NewOrm()
- sql := `SELECT * FROM chart_classify WHERE parent_id = ? AND chart_classify_name = ? AND chart_classify_id <> ? LIMIT 1`
- err = o.Raw(sql, parentId, classifyName, classifyId).QueryRow(&item)
- return
- }
- // GetChartClassifyByIdList
- // @Description: 根据分类ID列表获取分类
- // @author: Roc
- // @datetime 2024-04-01 13:21:48
- // @param classifyId []int
- // @return items []*ChartClassify
- // @return err error
- func GetChartClassifyByIdList(classifyIdList []int) (items []*ChartClassify, err error) {
- num := len(classifyIdList)
- if num <= 0 {
- return
- }
- o := orm.NewOrm()
- sql := `SELECT * FROM chart_classify WHERE chart_classify_id in (` + utils.GetOrmInReplace(num) + `) `
- _, err = o.Raw(sql, classifyIdList).QueryRows(&items)
- return
- }
- // GetChartClassifyBySourceAndIsJoinPermission
- // @Description: 根据分类类型和是否涉密获取分类列表
- // @author: Roc
- // @datetime 2024-03-29 10:30:21
- // @param source int
- // @param isJoinPermission int
- // @return items []*ChartClassify
- // @return err error
- func GetChartClassifyBySourceAndIsJoinPermission(source, isJoinPermission int) (items []*ChartClassify, err error) {
- o := orm.NewOrm()
- sql := `SELECT * FROM chart_classify WHERE source = ? AND is_join_permission = ? `
- _, err = o.Raw(sql, source, isJoinPermission).QueryRows(&items)
- return
- }
|