chart_classify.go 22 KB

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