package data_manage import ( "eta_gn/eta_api/global" "eta_gn/eta_api/utils" "time" ) // BaseFromSciClassify SMM原始数据分类表 type BaseFromSciClassify struct { ClassifyId int `orm:"column(classify_id);pk" gorm:"primaryKey" ` 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) { err = global.DmSQL["data"].Create(item).Error if err != nil { return } lastId = int64(item.ClassifyId) return } // GetBaseFromSciClassifyCount 获取分类名称的个数 func GetBaseFromSciClassifyCount(classifyName string, parentId int) (count int, err error) { o := global.DmSQL["data"] sql := `SELECT COUNT(1) AS count FROM base_from_sci_classify WHERE classify_name=? AND parent_id=? ` err = o.Raw(sql, classifyName, parentId).Scan(&count).Error 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 := global.DmSQL["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).Scan(&count).Error return } // GetBaseFromSciClassifyById 通过分类id的获取分类信息 func GetBaseFromSciClassifyById(classifyId int) (item *BaseFromSciClassify, err error) { o := global.DmSQL["data"] sql := `SELECT * FROM base_from_sci_classify WHERE classify_id=? ` err = o.Raw(sql, classifyId).First(&item).Error return } // EditBaseFromSciClassify 修改SMM原始数据分类 func EditBaseFromSciClassify(classifyId int, classifyName string) (err error) { sql := `UPDATE base_from_sci_classify SET classify_name=?,modify_time=NOW() WHERE classify_id=? ` err = global.DmSQL["data"].Exec(sql, classifyName, classifyId).Error 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) { sql := `UPDATE base_from_sci_classify SET classify_name_en = ?,modify_time=NOW() WHERE classify_id=? ` err = global.DmSQL["data"].Exec(sql, classifyNameEn, classifyId).Error return } // UpdateBaseFromSciClassifySort 修改SMM原始数据分类的排序 func UpdateBaseFromSciClassifySort(classifyId int) (err error) { sql := `UPDATE base_from_sci_classify SET sort=classify_id, modify_time=NOW() WHERE classify_id=? ` err = global.DmSQL["data"].Exec(sql, classifyId).Error 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 `gorm:"-" description:"下级"` } type BaseFromSciClassifyNameItems struct { ClassifyId int `description:"分类ID"` ClassifyName string `description:"分类名称"` ParentId int `description:"父级id"` Children []*BaseFromSciClassifyNameItems `gorm:"-" 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 := global.DmSQL["data"] sql := ` SELECT * FROM base_from_sci_classify WHERE parent_id=? order by sort asc,classify_id asc` err = o.Raw(sql, parentId).Scan(&items).Error return } // GetAllBaseFromSciClassify 获取所有的分类列表数据 func GetAllBaseFromSciClassify() (items []*BaseFromSciClassifyItems, err error) { sql := ` SELECT * FROM base_from_sci_classify WHERE parent_id <> 0 order by sort asc,classify_id asc` err = global.DmSQL["data"].Raw(sql).Scan(&items).Error 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 } // MoveUpSciIndexClassifyBySort 往上移动 func MoveUpSciIndexClassifyBySort(parentId, nextSort, currentSort int) (err error) { sql := `update base_from_sci_classify set sort = sort + 1 where parent_id=? and sort >= ? and sort< ?` err = global.DmSQL["data"].Exec(sql, parentId, nextSort, currentSort).Error return } // MoveDownSciIndexClassifyBySort 往下移动 func MoveDownSciIndexClassifyBySort(parentId, prevSort, currentSort int) (err error) { o := global.DmSQL["data"] sql := `update base_from_sci_classify set sort = sort - 1 where parent_id=? and sort <= ? and sort> ? ` err = o.Exec(sql, parentId, prevSort, currentSort).Error return } // GetSciIndexClassifyMinSort 获取最小不等于0的排序 func GetSciIndexClassifyMinSort(parentId int) (sort int, err error) { o := global.DmSQL["data"] sql := `select min(sort) from base_from_sci_classify where parent_id=? and sort <> 0 ` err = o.Raw(sql, parentId).Scan(&sort).Error return } // Update 更新分类基础信息 func (BaseFromSciClassify *BaseFromSciClassify) Update(cols []string) (err error) { err = global.DmSQL["data"].Select(cols).Updates(BaseFromSciClassify).Error return } type AddSciClassifyResp struct { ClassifyId int } // DeleteSciClassifyByClassifyId 根据分类id删除对应的指标分类 func DeleteSciClassifyByClassifyId(classifyIdList []int) (err error) { o := global.DmSQL["data"] num := len(classifyIdList) if num <= 0 { return } //删除分类 sql := `DELETE FROM base_from_sci_classify WHERE classify_id IN (` + utils.GetOrmInReplace(num) + `) ` err = o.Exec(sql, classifyIdList).Error return } // AddSciClassifyMulti 批量新增SMM类别 func AddSciClassifyMulti(list []*BaseFromSciClassify) (err error) { err = global.DmSQL["data"].CreateInBatches(list, utils.MultiAddNum).Error return } // InitSciClassifySort 初始化sort值 func InitSciClassifySort() (err error) { sql := `UPDATE base_from_sci_classify SET modify_time=NOW(), sort = classify_id` err = global.DmSQL["data"].Exec(sql).Error return } // InitSciIndexClassifyId 历史数据的classifyId值 func InitSciIndexClassifyId() (err error) { 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 = global.DmSQL["data"].Exec(sql).Error return }