123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259 |
- package data_manage
- import (
- "eta/eta_api/utils"
- "fmt"
- "github.com/beego/beego/v2/client/orm"
- "time"
- )
- // BaseFromSciClassify SMM原始数据分类表
- type BaseFromSciClassify struct {
- ClassifyId int `orm:"column(classify_id);pk"`
- ClassifyName string `description:"分类名称"`
- ParentId int `description:"父级id"`
- SysUserId int `description:"创建人id"`
- SysUserRealName string `description:"创建人姓名"`
- Level int `description:"层级"`
- Sort int `description:"排序字段,越小越靠前,默认值:10"`
- ModifyTime time.Time `description:"修改时间"`
- CreateTime time.Time `description:"创建时间"`
- ClassifyNameEn string `description:"英文分类名称"`
- }
- // AddBaseFromSciClassify 添加SMM原始数据分类
- func AddBaseFromSciClassify(item *BaseFromSciClassify) (lastId int64, err error) {
- o := orm.NewOrmUsingDB("data")
- lastId, err = o.Insert(item)
- return
- }
- // GetBaseFromSciClassifyCount 获取分类名称的个数
- func GetBaseFromSciClassifyCount(classifyName string, parentId int) (count int, err error) {
- o := orm.NewOrmUsingDB("data")
- sql := `SELECT COUNT(1) AS count FROM base_from_sci_classify WHERE classify_name=? AND parent_id=? `
- err = o.Raw(sql, classifyName, parentId).QueryRow(&count)
- return
- }
- // GetBaseFromSciClassifyEnCount
- // @Description: 获取英文分类名称的个数
- // @author: Roc
- // @datetime 2024-04-16 16:56:14
- // @param classifyNameEn string
- // @param parentId int
- // @return count int
- // @return err error
- func GetBaseFromSciClassifyEnCount(classifyNameEn string, parentId int) (count int, err error) {
- o := orm.NewOrmUsingDB("data")
- sql := `SELECT COUNT(1) AS count FROM base_from_sci_classify WHERE classify_name_en=? AND parent_id=? `
- err = o.Raw(sql, classifyNameEn, parentId).QueryRow(&count)
- return
- }
- // GetBaseFromSciClassifyById 通过分类id的获取分类信息
- func GetBaseFromSciClassifyById(classifyId int) (item *BaseFromSciClassify, err error) {
- o := orm.NewOrmUsingDB("data")
- sql := `SELECT * FROM base_from_sci_classify WHERE classify_id=? `
- err = o.Raw(sql, classifyId).QueryRow(&item)
- return
- }
- // EditBaseFromSciClassify 修改SMM原始数据分类
- func EditBaseFromSciClassify(classifyId int, classifyName string) (err error) {
- o := orm.NewOrmUsingDB("data")
- sql := `UPDATE base_from_sci_classify SET classify_name=?,modify_time=NOW() WHERE classify_id=? `
- _, err = o.Raw(sql, classifyName, classifyId).Exec()
- return
- }
- // EditBaseFromSciClassifyEn
- // @Description: 修改卓创(红桃3)数据英文分类
- // @author: Roc
- // @datetime 2024-04-16 16:56:42
- // @param classifyId int
- // @param classifyNameEn string
- // @return err error
- func EditBaseFromSciClassifyEn(classifyId int, classifyNameEn string) (err error) {
- o := orm.NewOrmUsingDB("data")
- sql := `UPDATE base_from_sci_classify SET classify_name_en = ?,modify_time=NOW() WHERE classify_id=? `
- _, err = o.Raw(sql, classifyNameEn, classifyId).Exec()
- return
- }
- // UpdateBaseFromSciClassifySort 修改SMM原始数据分类的排序
- func UpdateBaseFromSciClassifySort(classifyId int) (err error) {
- o := orm.NewOrmUsingDB("data")
- sql := `UPDATE base_from_sci_classify SET sort=classify_id, modify_time=NOW() WHERE classify_id=? `
- _, err = o.Raw(sql, classifyId).Exec()
- return
- }
- type BaseFromSciClassifyItems struct {
- ClassifyId int `description:"分类ID"`
- BaseFromSciIndexId int `description:"指标类型ID"`
- BaseFromSciIndexCode string `description:"指标唯一编码"`
- ClassifyName string `description:"分类名称"`
- ClassifyNameEn string `description:"英文分类名称"`
- ParentId int `description:"父级id"`
- Level int `description:"层级"`
- Sort int `description:"排序字段,越小越靠前,默认值:10"`
- //UniqueCode string `description:"唯一编码"`
- //ModifyTime time.Time `description:"修改时间"`
- //CreateTime time.Time `description:"创建时间"`
- Children []*BaseFromSciClassifyItems `description:"下级"`
- }
- type BaseFromSciClassifyNameItems struct {
- ClassifyId int `description:"分类ID"`
- ClassifyName string `description:"分类名称"`
- ParentId int `description:"父级id"`
- Children []*BaseFromSciClassifyNameItems `description:"下级"`
- }
- type BaseFromSciClassifyResp struct {
- List []*BaseFromSciClassifyItems
- }
- type BaseFromSciClassifyNameResp struct {
- List []*BaseFromSciClassifyNameItems
- }
- type BaseFromSciClassifyItemsButton struct {
- AddButton bool `description:"是否可添加"`
- OpButton bool `description:"是否可编辑"`
- DeleteButton bool `description:"是否可删除"`
- MoveButton bool `description:"是否可移动"`
- }
- // GetBaseFromSciClassifyByParentId 根据上级id获取当下的分类列表数据
- func GetBaseFromSciClassifyByParentId(parentId int) (items []*BaseFromSciClassifyItems, err error) {
- o := orm.NewOrmUsingDB("data")
- sql := ` SELECT * FROM base_from_sci_classify WHERE parent_id=? order by sort asc,classify_id asc`
- _, err = o.Raw(sql, parentId).QueryRows(&items)
- return
- }
- // GetAllBaseFromSciClassify 获取所有的分类列表数据
- func GetAllBaseFromSciClassify() (items []*BaseFromSciClassifyItems, err error) {
- o := orm.NewOrmUsingDB("data")
- sql := ` SELECT * FROM base_from_sci_classify WHERE parent_id <> 0 order by sort asc,classify_id asc`
- _, err = o.Raw(sql).QueryRows(&items)
- return
- }
- type DeleteBaseFromSciClassifyReq struct {
- ClassifyId int `description:"分类id"`
- EdbInfoId int `description:"指标id"`
- }
- type BaseFromSciClassifyListResp struct {
- AllNodes []*BaseFromSciClassifyItems
- CanOpClassify bool `description:"是否允许操作分类"`
- }
- type BaseFromSciClassifySimplify struct {
- ClassifyId int `description:"分类id"`
- ClassifyName string `description:"分类名称"`
- ParentId int
- }
- // GetFirstBaseFromSciClassify 获取当前分类下,且排序数相同 的排序第一条的数据
- func GetFirstBaseFromSciClassify() (item *BaseFromSciClassify, err error) {
- o := orm.NewOrmUsingDB("data")
- sql := ` SELECT * FROM base_from_sci_classify order by sort asc,classify_id asc limit 1`
- err = o.Raw(sql).QueryRow(&item)
- return
- }
- // UpdateBaseFromSciClassifySortByClassifyId 根据分类id更新排序
- func UpdateBaseFromSciClassifySortByClassifyId(parentId, classifyId, nowSort int, updateSort string) (err error) {
- o := orm.NewOrmUsingDB("data")
- sql := ` update base_from_sci_classify set sort = ` + updateSort + ` WHERE parent_id=? AND sort > ? `
- if classifyId > 0 {
- sql += ` or ( classify_id > ` + fmt.Sprint(classifyId) + ` and sort = ` + fmt.Sprint(nowSort) + `)`
- }
- _, err = o.Raw(sql, parentId, nowSort).Exec()
- return
- }
- // MoveUpSciIndexClassifyBySort 往上移动
- func MoveUpSciIndexClassifyBySort(parentId, nextSort, currentSort int) (err error) {
- o := orm.NewOrmUsingDB("data")
- sql := `update base_from_sci_classify set sort = sort + 1 where parent_id=? and sort >= ? and sort< ?`
- _, err = o.Raw(sql, parentId, nextSort, currentSort).Exec()
- return
- }
- // MoveDownSciIndexClassifyBySort 往下移动
- func MoveDownSciIndexClassifyBySort(parentId, prevSort, currentSort int) (err error) {
- o := orm.NewOrmUsingDB("data")
- sql := `update base_from_sci_classify set sort = sort - 1 where parent_id=? and sort <= ? and sort> ? `
- _, err = o.Raw(sql, parentId, prevSort, currentSort).Exec()
- return
- }
- // GetSciIndexClassifyMinSort 获取最小不等于0的排序
- func GetSciIndexClassifyMinSort(parentId int) (sort int, err error) {
- o := orm.NewOrmUsingDB("data")
- sql := `select min(sort) from base_from_sci_classify where parent_id=? and sort <> 0 `
- err = o.Raw(sql, parentId).QueryRow(&sort)
- return
- }
- // Update 更新分类基础信息
- func (BaseFromSciClassify *BaseFromSciClassify) Update(cols []string) (err error) {
- o := orm.NewOrmUsingDB("data")
- _, err = o.Update(BaseFromSciClassify, cols...)
- return
- }
- type AddSciClassifyResp struct {
- ClassifyId int
- }
- // DeleteSciClassifyByClassifyId 根据分类id删除对应的指标分类
- func DeleteSciClassifyByClassifyId(classifyIdList []int) (err error) {
- o := orm.NewOrmUsingDB("data")
- num := len(classifyIdList)
- if num <= 0 {
- return
- }
- //删除分类
- sql := `DELETE FROM base_from_sci_classify WHERE classify_id IN (` + utils.GetOrmInReplace(num) + `) `
- _, err = o.Raw(sql, classifyIdList).Exec()
- return
- }
- // AddSciClassifyMulti 批量新增SMM类别
- func AddSciClassifyMulti(list []*BaseFromSciClassify) (err error) {
- o := orm.NewOrmUsingDB("data")
- _, err = o.InsertMulti(1, list)
- return
- }
- // InitSciClassifySort 初始化sort值
- func InitSciClassifySort() (err error) {
- o := orm.NewOrmUsingDB("data")
- sql := `UPDATE base_from_sci_classify
- SET modify_time=NOW(), sort = classify_id`
- _, err = o.Raw(sql).Exec()
- return
- }
- // InitSciIndexClassifyId 历史数据的classifyId值
- func InitSciIndexClassifyId() (err error) {
- o := orm.NewOrmUsingDB("data")
- sql := `UPDATE base_from_sci_index s
- LEFT JOIN (
- SELECT
- c1.classify_id,
- CONCAT( c2.classify_name, c1.classify_name ) AS type_name
- FROM
- base_from_sci_classify c1
- LEFT JOIN base_from_sci_classify c2 ON c1.parent_id = c2.classify_id
- ) AS t ON CONCAT( s.type_2, s.type_3 ) = t.type_name
- SET s.classify_id = t.classify_id, s.modify_time=NOW() where s.type_2 <>""`
- _, err = o.Raw(sql).Exec()
- return
- }
|