chart_classify.go 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625
  1. package data_manage
  2. import (
  3. "eta/eta_api/utils"
  4. "fmt"
  5. "time"
  6. "database/sql"
  7. "eta/eta_api/global"
  8. )
  9. type ChartClassify struct {
  10. ChartClassifyId int `orm:"column(chart_classify_id);pk" gorm:"primaryKey" `
  11. ChartClassifyName string `description:"分类名称"`
  12. ParentId int `description:"父级id"`
  13. HasData int `description:"是否含有指标数据"`
  14. CreateTime time.Time `description:"创建时间"`
  15. ModifyTime time.Time `description:"修改时间"`
  16. SysUserId int `description:"创建人id"`
  17. SysUserRealName string `description:"创建人姓名"`
  18. Level int `description:"层级"`
  19. UniqueCode string `description:"唯一编码"`
  20. Sort int `description:"排序字段,越小越靠前,默认值:10"`
  21. Source int `description:"1:ETA图库;2:商品价格曲线"`
  22. IsJoinPermission int `description:"是否加入权限管控,0:不加入;1:加入;默认:0"`
  23. ChartClassifyNameEn string `description:"英文分类名称"`
  24. RootId int `description:"顶级ID"`
  25. ChartClassifyNamePath string `description:"分类名称的完整路径,格式为:父级分类名称|当前分类名称"`
  26. ChartClassifyIdPath string `description:"分类的完整路径,格式为:父级ID,当前ID"`
  27. }
  28. func AddChartClassify(item *ChartClassify) (lastId int64, err error) {
  29. err = global.DbMap[utils.DbNameIndex].Create(item).Error
  30. lastId = int64(item.ChartClassifyId)
  31. return
  32. }
  33. type AddChartClassifyReq struct {
  34. ChartClassifyName string `description:"分类名称"`
  35. ParentId int `description:"父级id,第一级传0"`
  36. Level int `description:"层级,第一级传0,其余传上一级的层级"`
  37. }
  38. // GetChartClassifyCount
  39. // @Description: 根据图表分类名称获取对应的数量
  40. // @author: Roc
  41. // @datetime 2024-04-16 18:13:40
  42. // @param chartClassifyName string
  43. // @param parentId int
  44. // @param source int
  45. // @return count int
  46. // @return err error
  47. func GetChartClassifyCount(chartClassifyName string, parentId, source int) (count int, err error) {
  48. o := global.DbMap[utils.DbNameIndex]
  49. sql := `SELECT COUNT(1) AS count FROM chart_classify WHERE parent_id=? AND source = ? AND chart_classify_name=? `
  50. err = o.Raw(sql, parentId, source, chartClassifyName).Scan(&count).Error
  51. return
  52. }
  53. // GetChartClassifyEnCount
  54. // @Description: 根据图表分类英文名称获取对应的数量
  55. // @author: Roc
  56. // @datetime 2024-04-16 18:13:24
  57. // @param chartClassifyNameEn string
  58. // @param parentId int
  59. // @param source int
  60. // @return count int
  61. // @return err error
  62. func GetChartClassifyEnCount(chartClassifyNameEn string, parentId, source int) (count int, err error) {
  63. o := global.DbMap[utils.DbNameIndex]
  64. sql := `SELECT COUNT(1) AS count FROM chart_classify WHERE parent_id=? AND source = ? AND chart_classify_name_en = ? `
  65. err = o.Raw(sql, parentId, source, chartClassifyNameEn).Scan(&count).Error
  66. return
  67. }
  68. type EditChartClassifyReq struct {
  69. ChartClassifyName string `description:"分类名称"`
  70. ChartClassifyId int `description:"分类id"`
  71. ParentId int `description:"父级分类id"`
  72. }
  73. func GetChartClassifyById(classifyId int) (item *ChartClassify, err error) {
  74. o := global.DbMap[utils.DbNameIndex]
  75. sql := `SELECT * FROM chart_classify WHERE chart_classify_id=? `
  76. err = o.Raw(sql, classifyId).First(&item).Error
  77. return
  78. }
  79. func GetChartClassifyCountById(classifyId int) (count int, err error) {
  80. o := global.DbMap[utils.DbNameIndex]
  81. sqlStr := `SELECT count(1) AS count FROM chart_classify WHERE chart_classify_id=? `
  82. var totalNull sql.NullInt64
  83. err = o.Raw(sqlStr, classifyId).Scan(&count).Error
  84. if !totalNull.Valid {
  85. count = 0
  86. } else {
  87. count = int(totalNull.Int64)
  88. }
  89. return
  90. }
  91. // EditChartClassify
  92. // @Description: 修改图表分类的名称
  93. // @author: Roc
  94. // @datetime 2024-04-16 18:12:51
  95. // @param classifyId int
  96. // @param source int
  97. // @param chartClassifyName string
  98. // @return err error
  99. func EditChartClassify(classifyId, source int, chartClassifyName string) (err error) {
  100. sql := `UPDATE chart_classify SET chart_classify_name=?,modify_time=NOW() WHERE chart_classify_id=? AND source = ? `
  101. err = global.DbMap[utils.DbNameIndex].Exec(sql, chartClassifyName, classifyId, source).Error
  102. return
  103. }
  104. // EditChartClassifyEn
  105. // @Description: 修改图表分类的英文名称
  106. // @author: Roc
  107. // @datetime 2024-04-16 18:12:40
  108. // @param classifyId int
  109. // @param source int
  110. // @param chartClassifyNameEn string
  111. // @return err error
  112. func EditChartClassifyEn(classifyId, source int, chartClassifyNameEn string) (err error) {
  113. sql := `UPDATE chart_classify SET chart_classify_name_en = ?,modify_time=NOW() WHERE chart_classify_id=? AND source = ? `
  114. err = global.DbMap[utils.DbNameIndex].Exec(sql, chartClassifyNameEn, classifyId, source).Error
  115. return
  116. }
  117. type DeleteChartClassifyReq struct {
  118. ChartClassifyId int `description:"分类id"`
  119. ChartInfoId int `description:"指标id"`
  120. }
  121. func GetChartInfoCountByClassifyId(classifyId int) (count int, err error) {
  122. sqlStr := ` SELECT COUNT(1) AS count FROM chart_info AS a
  123. WHERE a.chart_classify_id IN(
  124. SELECT t.chart_classify_id FROM
  125. (
  126. SELECT rd.*
  127. FROM (SELECT * FROM chart_classify WHERE parent_id IS NOT NULL) rd,
  128. (SELECT @pid := ?) pd
  129. WHERE FIND_IN_SET(parent_id, @pid) > 0
  130. AND @pid := CONCAT(@pid, ',', chart_classify_id)
  131. UNION SELECT * FROM chart_classify WHERE chart_classify_id = @pid
  132. )AS t
  133. ) `
  134. var totalNull sql.NullInt64
  135. err = global.DbMap[utils.DbNameIndex].Raw(sqlStr, classifyId).Scan(&totalNull).Error
  136. if !totalNull.Valid {
  137. count = 0
  138. } else {
  139. count = int(totalNull.Int64)
  140. }
  141. return
  142. }
  143. func DeleteChartClassify(classifyId int) (err error) {
  144. sql := ` DELETE FROM chart_classify
  145. WHERE chart_classify_id IN(
  146. SELECT t.chart_classify_id FROM
  147. (
  148. SELECT rd.*
  149. FROM (SELECT * FROM chart_classify WHERE parent_id IS NOT NULL) rd,
  150. (SELECT @pid := ?) pd
  151. WHERE FIND_IN_SET(parent_id, @pid) > 0
  152. AND @pid := CONCAT(@pid, ',', chart_classify_id)
  153. UNION SELECT * FROM chart_classify WHERE chart_classify_id = @pid
  154. )AS t
  155. ) `
  156. err = global.DbMap[utils.DbNameIndex].Exec(sql, classifyId).Error
  157. return
  158. }
  159. // GetChartClassifyByParentId
  160. // @param source int 1:ETA图库;2:商品价格曲线;3:相关性图表
  161. func GetChartClassifyByParentId(parentId, source int) (items []*ChartClassifyItems, err error) {
  162. sql := ` SELECT * FROM chart_classify WHERE parent_id=? AND source = ? order by sort asc,chart_classify_id asc`
  163. err = global.DbMap[utils.DbNameIndex].Raw(sql, parentId, source).Find(&items).Error
  164. return
  165. }
  166. // GetChartClassifyAll
  167. // @param source int 1:ETA图库;2:商品价格曲线;3:相关性图表
  168. func GetChartClassifyAll(source int) (items []*ChartClassifyItems, err error) {
  169. sql := ` SELECT * FROM chart_classify WHERE parent_id<>0 AND source = ? order by sort asc,chart_classify_id asc`
  170. err = global.DbMap[utils.DbNameIndex].Raw(sql, source).Find(&items).Error
  171. return
  172. }
  173. // GetChartClassifyBySource 获取图表分类列表
  174. func GetChartClassifyBySource(source int) (items []*ChartClassifyItems, err error) {
  175. sql := ` SELECT * FROM chart_classify WHERE source = ? ORDER BY level ASC,chart_classify_id ASC`
  176. err = global.DbMap[utils.DbNameIndex].Raw(sql, source).Find(&items).Error
  177. return
  178. }
  179. type ChartClassifyItems struct {
  180. ChartClassifyId int `description:"分类id"`
  181. ChartInfoId int `description:"指标id"`
  182. ChartClassifyName string
  183. ChartClassifyNameEn string
  184. ParentId int
  185. Level int `description:"层级"`
  186. Sort int `description:"排序字段,越小越靠前,默认值:10"`
  187. UniqueCode string `description:"唯一编码"`
  188. Source int `description:"来源id"`
  189. SourceName string `description:"来源名称"`
  190. SysUserId int `description:"创建人id"`
  191. SysUserRealName string `description:"创建人姓名"`
  192. DateType int `description:"日期类型:1:00年至今,2:10年至今,3:15年至今,4:年初至今,5:自定义时间"`
  193. StartDate string `description:"自定义开始日期"`
  194. EndDate string `description:"自定义结束日期"`
  195. ChartType int `description:"生成样式:1:曲线图,2:季节性图"`
  196. Calendar string `description:"公历/农历"`
  197. SeasonStartDate string `description:"季节性图开始日期"`
  198. SeasonEndDate string `description:"季节性图开始日期"`
  199. Children []*ChartClassifyItems `gorm:"-"`
  200. Button ChartClassifyItemsButton `gorm:"-" description:"按钮权限"`
  201. IsJoinPermission int `description:"是否加入权限管控,0:不加入;1:加入;默认:0"`
  202. HaveOperaAuth bool `description:"是否有数据权限,默认:false"`
  203. Disable bool `description:"勾选是否禁用"`
  204. }
  205. // ChartClassifyItemsButton 操作按钮
  206. type ChartClassifyItemsButton struct {
  207. AddButton bool `description:"是否可添加"`
  208. OpButton bool `description:"是否可编辑"`
  209. DeleteButton bool `description:"是否可删除"`
  210. MoveButton bool `description:"是否可移动"`
  211. }
  212. type ChartClassifyListResp struct {
  213. AllNodes []*ChartClassifyItems
  214. Language string `description:"指标的展示语言,CN:中文,EN:英文"`
  215. CanOpClassify bool `description:"是否允许操作分类"`
  216. }
  217. type ChartClassifyDeleteCheckResp struct {
  218. DeleteStatus int `description:"检测状态:0:默认值,如果为0,继续走其他校验,1:该分类下关联图表不可删除,2:确认删除当前目录及包含的子目录吗"`
  219. TipsMsg string `description:"提示信息"`
  220. }
  221. type ChartClassifyDeleteCheckReq struct {
  222. ChartClassifyId int `description:"分类id"`
  223. ChartInfoId int `description:"指标id"`
  224. }
  225. func GetChartClassifyCountByClassifyId(chartClassifyId int) (count int, err error) {
  226. sql := ` SELECT COUNT(1) AS count FROM (
  227. SELECT rd.*
  228. FROM (SELECT * FROM chart_classify WHERE parent_id IS NOT NULL) rd,
  229. (SELECT @pid := ?) pd
  230. WHERE FIND_IN_SET(parent_id, @pid) > 0
  231. AND @pid := CONCAT(@pid, ',', chart_classify_id)
  232. UNION SELECT * FROM chart_classify WHERE chart_classify_id = @pid
  233. )AS t
  234. WHERE t.chart_classify_id<>? `
  235. err = global.DbMap[utils.DbNameIndex].Raw(sql, chartClassifyId, chartClassifyId).Scan(&count).Error
  236. return
  237. }
  238. func GetChartClassifyByCondition(condition string, pars []interface{}) (item *ChartClassify, err error) {
  239. o := global.DbMap[utils.DbNameIndex]
  240. sql := ` SELECT * FROM chart_classify WHERE 1=1 `
  241. if condition != "" {
  242. sql += condition
  243. }
  244. err = o.Raw(sql, pars...).First(&item).Error
  245. return
  246. }
  247. // MoveChartClassifyReq 移动图表分类请求参数
  248. type MoveChartClassifyReq struct {
  249. ClassifyId int `description:"分类id"`
  250. ParentClassifyId int `description:"父级分类id"`
  251. PrevClassifyId int `description:"上一个兄弟节点分类id"`
  252. NextClassifyId int `description:"下一个兄弟节点分类id"`
  253. ChartInfoId int `description:"图表ID, 如果图表ID有值,则移动对象为图表,否则认为移动对象分类"`
  254. PrevChartInfoId int `description:"上一个图表ID"`
  255. NextChartInfoId int `description:"下一个图表ID"`
  256. }
  257. // GetFirstChartClassifyByParentId 获取当前父级图表分类下的排序第一条的数据
  258. func GetFirstChartClassifyByParentId(parentId int) (item *ChartClassify, err error) {
  259. o := global.DbMap[utils.DbNameIndex]
  260. sql := ` SELECT * FROM chart_classify WHERE parent_id=? order by sort asc,chart_classify_id asc limit 1`
  261. err = o.Raw(sql, parentId).First(&item).Error
  262. return
  263. }
  264. // GetFirstChartClassifyByParentIdAndSource 获取当前父级图表分类下的排序第一条的数据
  265. func GetFirstChartClassifyByParentIdAndSource(parentId, source int) (item *ChartClassify, err error) {
  266. o := global.DbMap[utils.DbNameIndex]
  267. sql := ` SELECT * FROM chart_classify WHERE parent_id=? and source = ? order by sort asc,chart_classify_id asc limit 1`
  268. err = o.Raw(sql, parentId, source).First(&item).Error
  269. return
  270. }
  271. // UpdateChartClassifySortByParentId 根据图表父类id更新排序
  272. func UpdateChartClassifySortByParentId(parentId, classifyId, nowSort int, updateSort string) (err error) {
  273. o := global.DbMap[utils.DbNameIndex]
  274. sql := ` update chart_classify set sort = ` + updateSort + ` WHERE parent_id=? and sort > ? `
  275. if classifyId > 0 {
  276. sql += ` or ( chart_classify_id > ` + fmt.Sprint(classifyId) + ` and sort= ` + fmt.Sprint(nowSort) + `)`
  277. }
  278. err = o.Exec(sql, parentId, nowSort).Error
  279. return
  280. }
  281. // Update 更新图表分类基础信息
  282. func (chartClassify *ChartClassify) Update(cols []string) (err error) {
  283. err = global.DbMap[utils.DbNameIndex].Select(cols).Updates(chartClassify).Error
  284. return
  285. }
  286. // GetChartClassifyMaxSort 获取图表分类下最大的排序数
  287. func GetChartClassifyMaxSort(parentId, source int) (sort int, err error) {
  288. o := global.DbMap[utils.DbNameIndex]
  289. sql := `SELECT COALESCE(MAX(sort),0) AS sort FROM chart_classify WHERE parent_id=? AND source = ? `
  290. err = o.Raw(sql, parentId, source).Scan(&sort).Error
  291. return
  292. }
  293. type ChartClassifyView struct {
  294. ChartClassifyId int `orm:"column(chart_classify_id);pk" gorm:"primaryKey" `
  295. ChartClassifyName string `description:"分类名称"`
  296. ParentId int `description:"父级id"`
  297. }
  298. func GetChartClassifyViewById(classifyId int) (item *ChartClassifyView, err error) {
  299. o := global.DbMap[utils.DbNameIndex]
  300. sql := `SELECT * FROM chart_classify WHERE chart_classify_id=? `
  301. err = o.Raw(sql, classifyId).First(&item).Error
  302. return
  303. }
  304. func GetChartClassifyByParentIdFromETA(parentId int) (items []*ChartClassifyItems, err error) {
  305. sql := ` SELECT * FROM chart_classify WHERE parent_id=? AND source = 1 order by sort asc,chart_classify_id asc`
  306. err = global.DbMap[utils.DbNameIndex].Raw(sql, parentId).Find(&items).Error
  307. return
  308. }
  309. func GetChartClassifyAllFromETA() (items []*ChartClassifyItems, err error) {
  310. sql := ` SELECT * FROM chart_classify WHERE parent_id<>0 AND source = 1 order by sort asc,chart_classify_id asc`
  311. err = global.DbMap[utils.DbNameIndex].Raw(sql).Find(&items).Error
  312. return
  313. }
  314. func GetChartClassifyTwo(source int) (items []*ChartClassifyItems, err error) {
  315. sql := ` SELECT * FROM chart_classify WHERE level=3 AND source = ? order by sort asc,chart_classify_id asc`
  316. err = global.DbMap[utils.DbNameIndex].Raw(sql, source).Find(&items).Error
  317. return
  318. }
  319. func GetChartClassifyByLevel(level, source int) (items []*ChartClassifyItems, err error) {
  320. o := global.DbMap[utils.DbNameIndex]
  321. sql := ` SELECT * FROM chart_classify WHERE level=? AND source = ? order by sort asc,chart_classify_id asc`
  322. err = o.Raw(sql, level, source).Scan(&items).Error
  323. return
  324. }
  325. func EditChartClassifySysUser(classifyId, sysUserId int, chartClassifyName string) (err error) {
  326. o := global.DbMap[utils.DbNameIndex]
  327. sql := `UPDATE chart_classify SET sys_user_id=?,sys_user_real_name=?,modify_time=NOW() WHERE parent_id=? AND level=3 `
  328. err = o.Exec(sql, sysUserId, chartClassifyName, classifyId).Error
  329. return
  330. }
  331. func GetAllChartClassifyItemsBySource(source int) (items []*ChartClassifyItems, err error) {
  332. o := global.DbMap[utils.DbNameIndex]
  333. sql := ` SELECT * FROM chart_classify WHERE source = ? order by sort ASC,chart_classify_id ASC`
  334. err = o.Raw(sql, source).Scan(&items).Error
  335. return
  336. }
  337. // GetCrossVarietyChartClassifyBySysUserId
  338. // @Description: 根据创建人获取跨品种分析的分类
  339. // @author: Roc
  340. // @datetime 2023-11-24 14:05:43
  341. // @param sysUserId int
  342. // @return item *ChartClassify
  343. // @return err error
  344. func GetCrossVarietyChartClassifyBySysUserId(sysUserId int) (item *ChartClassify, err error) {
  345. o := global.DbMap[utils.DbNameIndex]
  346. sql := `SELECT * FROM chart_classify WHERE source = ? AND sys_user_id=?`
  347. err = o.Raw(sql, utils.CHART_SOURCE_CROSS_HEDGING, sysUserId).First(&item).Error
  348. return
  349. }
  350. // GetChartClassifyByParentIdAndName 根据父级ID和名称获取分类
  351. func GetChartClassifyByParentIdAndName(parentId int, classifyName string, classifyId int) (item *ChartClassify, err error) {
  352. sql := `SELECT * FROM chart_classify WHERE parent_id = ? AND chart_classify_name = ? AND chart_classify_id <> ? LIMIT 1`
  353. err = global.DbMap[utils.DbNameIndex].Raw(sql, parentId, classifyName, classifyId).First(&item).Error
  354. return
  355. }
  356. // GetChartClassifyByIdList
  357. // @Description: 根据分类ID列表获取分类
  358. // @author: Roc
  359. // @datetime 2024-04-01 13:21:48
  360. // @param classifyId []int
  361. // @return items []*ChartClassify
  362. // @return err error
  363. func GetChartClassifyByIdList(classifyIdList []int) (items []*ChartClassify, err error) {
  364. num := len(classifyIdList)
  365. if num <= 0 {
  366. return
  367. }
  368. o := global.DbMap[utils.DbNameIndex]
  369. sql := `SELECT * FROM chart_classify WHERE chart_classify_id in (` + utils.GetOrmInReplace(num) + `) `
  370. err = o.Raw(sql, classifyIdList).Find(&items).Error
  371. return
  372. }
  373. // GetChartClassifyBySourceAndIsJoinPermission
  374. // @Description: 根据分类类型和是否涉密获取分类列表
  375. // @author: Roc
  376. // @datetime 2024-03-29 10:30:21
  377. // @param source int
  378. // @param isJoinPermission int
  379. // @return items []*ChartClassify
  380. // @return err error
  381. func GetChartClassifyBySourceAndIsJoinPermission(source, isJoinPermission int) (items []*ChartClassify, err error) {
  382. o := global.DbMap[utils.DbNameIndex]
  383. sql := `SELECT * FROM chart_classify WHERE source = ? AND is_join_permission = ? `
  384. err = o.Raw(sql, source, isJoinPermission).Scan(&items).Error
  385. return
  386. }
  387. type ChartClassifyIdItems struct {
  388. ChartClassifyId int `description:"分类id"`
  389. ChartClassifyName string `description:"分类名称"`
  390. UniqueCode string `description:"唯一编码"`
  391. ParentId int `description:"父级分类id"`
  392. Level int `description:"层级"`
  393. RootId int `description:"顶级分类id"`
  394. IsJoinPermission int `description:"是否加入权限管控,0:不加入;1:加入;默认:0" json:"-"`
  395. HaveOperaAuth bool `description:"是否有该数据权限,默认:false"`
  396. }
  397. func GetChartClassifyByRootIdLevel(rootId, source int, orderStr string) (items []*ChartClassifyIdItems, err error) {
  398. o := global.DbMap[utils.DbNameIndex]
  399. sql := ` SELECT * FROM chart_classify WHERE root_id = ? AND source = ? `
  400. if orderStr != "" {
  401. sql += orderStr
  402. } else {
  403. sql += ` order by level desc, sort asc, chart_classify_id asc`
  404. }
  405. err = o.Raw(sql, rootId, source).Scan(&items).Error
  406. return
  407. }
  408. // UpdateChartClassifySortByParentIdAndSource 根据图表父类id更新排序
  409. func UpdateChartClassifySortByParentIdAndSource(parentId, classifyId, nowSort int, updateSort string, source int) (err error) {
  410. o := global.DbMap[utils.DbNameIndex]
  411. sql := ` update chart_classify set sort = ` + updateSort + ` WHERE parent_id=? and sort > ? AND source = ? `
  412. if classifyId > 0 {
  413. sql += ` or ( chart_classify_id > ` + fmt.Sprint(classifyId) + ` and sort= ` + fmt.Sprint(nowSort) + `)`
  414. }
  415. err = o.Exec(sql, parentId, nowSort, source).Error
  416. return
  417. }
  418. // GetChartClassifyAllBySource 根据来源获取所有分类
  419. func GetChartClassifyAllBySource(source int) (items []*ChartClassifyItems, err error) {
  420. sql := ` SELECT * FROM chart_classify WHERE source = ? ORDER BY parent_id ASC, sort ASC, chart_classify_id ASC`
  421. err = global.DbMap[utils.DbNameIndex].Raw(sql, source).Find(&items).Error
  422. return
  423. }
  424. // GetChartClassifyIdListByAdminId
  425. // @Description: 根据用户id和指标类型获取其关联的所有指标分类id列表
  426. // @author: Roc
  427. // @datetime 2024-09-11 15:52:48
  428. // @param adminId int
  429. // @param source int
  430. // @return chartClassifyIdList []int
  431. // @return err error
  432. func GetChartClassifyIdListByAdminId(adminId, source int) (chartClassifyIdList []int, err error) {
  433. sql := ` SELECT chart_classify_id FROM chart_info WHERE sys_user_id = ? AND source = ?`
  434. pars := []interface{}{adminId, source}
  435. sql += ` group by chart_classify_id `
  436. err = global.DbMap[utils.DbNameIndex].Raw(sql, pars...).Find(&chartClassifyIdList).Error
  437. return
  438. }
  439. // GetChartClassifyAndInfoByParentId
  440. func GetChartClassifyAndInfoByParentId(parentId int) (items []*ChartClassifyItems, err error) {
  441. sql := ` SELECT
  442. 0 AS chart_info_id,
  443. chart_classify_id,
  444. chart_classify_name,
  445. chart_classify_name_en,
  446. parent_id,
  447. create_time,
  448. modify_time,
  449. sys_user_id,
  450. sys_user_real_name,
  451. sort,
  452. level,
  453. unique_code,
  454. source,
  455. 0 as date_type,
  456. '' as start_date,
  457. '' as end_date,
  458. 0 as chart_type,
  459. '' as calendar,
  460. '' as season_start_date,
  461. '' as season_end_date
  462. FROM
  463. chart_classify
  464. WHERE
  465. parent_id = ? and source = 1 UNION ALL
  466. SELECT
  467. chart_info_id,
  468. chart_classify_id,
  469. chart_name AS chart_classify_name,
  470. chart_name_en AS chart_classify_name_en,
  471. 0 AS parent_id,
  472. create_time,
  473. modify_time,
  474. sys_user_id,
  475. sys_user_real_name,
  476. sort,
  477. 0 AS level,
  478. unique_code,
  479. source,
  480. date_type,
  481. start_date,
  482. end_date,
  483. chart_type,
  484. calendar,
  485. season_start_date,
  486. season_end_date
  487. FROM
  488. chart_info
  489. WHERE
  490. chart_classify_id = ? AND source = 1
  491. ORDER BY
  492. sort ASC,
  493. chart_classify_id ASC`
  494. err = global.DbMap[utils.DbNameIndex].Raw(sql, parentId, parentId).Find(&items).Error
  495. return
  496. }
  497. // GetChartClassifyAndInfoByParentId
  498. func GetChartClassifyAndInfoByParentIdForMe(parentId, adminId int) (items []*ChartClassifyItems, err error) {
  499. sql := ` SELECT
  500. 0 AS chart_info_id,
  501. chart_classify_id,
  502. chart_classify_name,
  503. chart_classify_name_en,
  504. parent_id,
  505. create_time,
  506. modify_time,
  507. sys_user_id,
  508. sys_user_real_name,
  509. sort,
  510. level,
  511. unique_code
  512. FROM
  513. chart_classify
  514. WHERE
  515. parent_id = ? and source = 1 UNION ALL
  516. SELECT
  517. chart_info_id,
  518. chart_classify_id,
  519. chart_name AS chart_classify_name,
  520. chart_name_en AS chart_classify_name_en,
  521. 0 AS parent_id,
  522. create_time,
  523. modify_time,
  524. sys_user_id,
  525. sys_user_real_name,
  526. sort,
  527. 0 AS level,
  528. unique_code
  529. FROM
  530. chart_info
  531. WHERE
  532. chart_classify_id = ? AND sys_user_id = ? AND source = 1
  533. ORDER BY
  534. sort ASC,
  535. chart_classify_id ASC`
  536. err = global.DbMap[utils.DbNameIndex].Raw(sql, parentId, parentId, adminId).Find(&items).Error
  537. return
  538. }
  539. func GetChartClassifiesById(chartClassifyId int) (items []*ChartClassifyItems, err error) {
  540. sql := `
  541. SELECT *
  542. FROM chart_classify
  543. WHERE chart_classify_id = ?
  544. OR parent_id = ?
  545. OR parent_id IN (
  546. SELECT chart_classify_id
  547. FROM chart_classify
  548. WHERE parent_id = ?
  549. );`
  550. err = global.DbMap[utils.DbNameIndex].Raw(sql, chartClassifyId, chartClassifyId, chartClassifyId).Find(&items).Error
  551. return
  552. }