edb_classify.go 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622
  1. package data_manage
  2. import (
  3. "eta_gn/eta_api/global"
  4. "eta_gn/eta_api/utils"
  5. "fmt"
  6. "time"
  7. )
  8. type EdbClassify struct {
  9. ClassifyId int `gorm:"primaryKey" `
  10. ClassifyType uint8 `description:"分类类型,0:普通指标分类,1:预测指标分类"`
  11. ClassifyName string `description:"分类名称"`
  12. ParentId int `description:"父级id"`
  13. RootId int `description:"顶级id"`
  14. HasData int `description:"是否含有指标数据"`
  15. CreateTime time.Time `description:"创建时间"`
  16. ModifyTime time.Time `description:"修改时间"`
  17. SysUserId int `description:"创建人id"`
  18. SysUserRealName string `description:"创建人姓名"`
  19. Level int `description:"层级"`
  20. UniqueCode string `description:"唯一编码"`
  21. Sort int `description:"排序字段,越小越靠前,默认值:10"`
  22. LastModifyUserId int `description:"最后修改人ID"`
  23. LastModifyUserRealName string `description:"最后修改人姓名"`
  24. IsJoinPermission int `description:"是否加入权限管控,0:不加入;1:加入;默认:0"`
  25. ClassifyNameEn string `description:"英文分类名称"`
  26. ClassifyNamePath string `description:"分类名称的完整路径,格式为:父级分类名称|当前分类名称"`
  27. ClassifyIdPath string `description:"分类的完整路径,格式为:父级ID,当前ID"`
  28. }
  29. func AddEdbClassify(item *EdbClassify) (err error) {
  30. err = global.DmSQL["data"].Create(item).Error
  31. return
  32. }
  33. type AddEdbClassifyReq struct {
  34. ClassifyName string `description:"分类名称"`
  35. ParentId int `description:"父级id,第一级传0"`
  36. Level int `description:"层级,第一级传0,其余传上一级的层级"`
  37. ClassifyType uint8 `description:"分类类型,0:普通指标分类,1:预测指标分类"`
  38. }
  39. // GetEdbClassifyCount
  40. // @Description: 根据父级id获取同级中文名称的数量
  41. // @author: Roc
  42. // @datetime 2024-04-17 14:12:22
  43. // @param classifyName string
  44. // @param parentId int
  45. // @param classifyType uint8
  46. // @return count int
  47. // @return err error
  48. func GetEdbClassifyCount(classifyName string, parentId int, classifyType uint8) (count int, err error) {
  49. sql := `SELECT COUNT(1) AS count FROM edb_classify WHERE parent_id=? AND classify_name=? AND classify_type = ? `
  50. err = global.DmSQL["data"].Raw(sql, parentId, classifyName, classifyType).Scan(&count).Error
  51. return
  52. }
  53. // GetEdbClassifyEnCount
  54. // @Description: 根据父级id获取同级英文名称的数量
  55. // @author: Roc
  56. // @datetime 2024-04-17 14:12:09
  57. // @param classifyNameEn string
  58. // @param parentId int
  59. // @param classifyType uint8
  60. // @return count int
  61. // @return err error
  62. func GetEdbClassifyEnCount(classifyNameEn string, parentId int, classifyType uint8) (count int, err error) {
  63. sql := `SELECT COUNT(1) AS count FROM edb_classify WHERE parent_id=? AND classify_name_en = ? AND classify_type = ? `
  64. err = global.DmSQL["data"].Raw(sql, parentId, classifyNameEn, classifyType).Scan(&count).Error
  65. return
  66. }
  67. type EditEdbClassifyReq struct {
  68. ClassifyName string `description:"分类名称"`
  69. ClassifyId int `description:"分类名称"`
  70. }
  71. func GetEdbClassifyById(classifyId int) (item *EdbClassify, err error) {
  72. sql := `SELECT * FROM edb_classify WHERE classify_id=? `
  73. err = global.DmSQL["data"].Raw(sql, classifyId).First(&item).Error
  74. return
  75. }
  76. func GetEdbClassifyCountById(classifyId int) (count int, err error) {
  77. sql := `SELECT count(1) AS count FROM edb_classify WHERE classify_id=? `
  78. err = global.DmSQL["data"].Raw(sql, classifyId).Scan(&count).Error
  79. return
  80. }
  81. // EditEdbClassify
  82. // @Description: 修改指标分类的中文名称
  83. // @author: Roc
  84. // @datetime 2024-04-17 14:14:48
  85. // @param classifyId int
  86. // @param classifyName string
  87. // @param userId int
  88. // @param userRealName string
  89. // @return err error
  90. func EditEdbClassify(classifyId int, classifyName string, userId int, userRealName string) (err error) {
  91. sql := `UPDATE edb_classify SET classify_name=?,modify_time=NOW(), last_modify_user_id = ?, last_modify_user_real_name = ? WHERE classify_id=? `
  92. err = global.DmSQL["data"].Exec(sql, classifyName, userId, userRealName, classifyId).Error
  93. return
  94. }
  95. type DeleteEdbClassifyReq struct {
  96. ClassifyId int `description:"分类id"`
  97. EdbInfoId int `description:"指标id"`
  98. }
  99. // TODO: sql优化,后续解决
  100. func GetEdbInfoCountByClassifyId(classifyId int) (count int, err error) {
  101. sql := `WITH RECURSIVE classify_cte(classify_id, parent_id) AS (
  102. SELECT classify_id, parent_id
  103. FROM edb_classify
  104. WHERE parent_id = ?
  105. UNION ALL
  106. SELECT e.classify_id, e.parent_id
  107. FROM edb_classify e
  108. INNER JOIN classify_cte c ON e.parent_id = c.classify_id
  109. )
  110. SELECT COUNT(1) AS COUNT
  111. FROM edb_info AS a
  112. WHERE a.classify_id IN (SELECT classify_id FROM classify_cte);`
  113. err = global.DmSQL["data"].Raw(sql, classifyId).Scan(&count).Error
  114. return
  115. }
  116. func DeleteEdbClassify(classifyId int) (err error) {
  117. sql := `WITH RECURSIVE ClassifyHierarchy ( classify_id, parent_id ) AS
  118. (
  119. SELECT classify_id,
  120. parent_id
  121. FROM edb_classify
  122. WHERE parent_id = ? OR classify_id=?
  123. UNION ALL
  124. SELECT e.classify_id,
  125. e.parent_id
  126. FROM edb_classify e
  127. INNER JOIN ClassifyHierarchy ch
  128. ON e.parent_id = ch.classify_id
  129. )
  130. DELETE
  131. FROM edb_classify
  132. WHERE classify_id IN ( SELECT classify_id
  133. FROM ClassifyHierarchy
  134. );`
  135. err = global.DmSQL["data"].Exec(sql, classifyId, classifyId).Error
  136. return
  137. }
  138. func GetEdbClassifyByParentId(parentId int, classifyType int8) (items []*EdbClassifyItems, err error) {
  139. o := global.DmSQL["data"]
  140. sql := ` SELECT * FROM edb_classify WHERE parent_id=? AND classify_type = ? order by sort asc,classify_id asc`
  141. err = o.Raw(sql, parentId, classifyType).Scan(&items).Error
  142. return
  143. }
  144. func GetEdbClassifyByRootIdLevel(rootId int, classifyType uint8, orderStr string) (items []*EdbClassifyItems, err error) {
  145. o := global.DmSQL["data"]
  146. sql := ` SELECT * FROM edb_classify WHERE root_id=? AND classify_type = ? `
  147. if orderStr != "" {
  148. sql += orderStr
  149. } else {
  150. sql += ` order by level desc, sort asc, classify_id asc`
  151. }
  152. err = o.Raw(sql, rootId, classifyType).Scan(&items).Error
  153. return
  154. }
  155. // GetAllEdbClassify 获取所有的普通指标的分类列表(包含第一级)
  156. func GetAllEdbClassify() (items []*EdbClassifyItems, err error) {
  157. o := global.DmSQL["data"]
  158. sql := ` SELECT * FROM edb_classify WHERE classify_type = 0 order by sort asc,classify_id asc`
  159. err = o.Raw(sql).Scan(&items).Error
  160. return
  161. }
  162. // GetPredictEdbClassifyAll 获取预测指标的分类列表
  163. func GetPredictEdbClassifyAll() (items []*EdbClassifyItems, err error) {
  164. o := global.DmSQL["data"]
  165. sql := ` SELECT * FROM edb_classify WHERE classify_type = 1 order by sort asc,classify_id asc`
  166. err = o.Raw(sql).Scan(&items).Error
  167. return
  168. }
  169. // GetAllEdbClassifyByType 根据类型获取分类列表
  170. func GetAllEdbClassifyByType(classifyType int) (items []*EdbClassifyItems, err error) {
  171. o := global.DmSQL["data"]
  172. sql := ` SELECT * FROM edb_classify WHERE classify_type = ? order by sort ASC,classify_id ASC`
  173. err = o.Raw(sql, classifyType).Scan(&items).Error
  174. return
  175. }
  176. type EdbClassifyItems struct {
  177. ClassifyId int `description:"分类id"`
  178. EdbInfoId int `description:"指标id"`
  179. ClassifyName string
  180. ClassifyNameEn string
  181. ParentId int
  182. RootId int `description:"顶级id"`
  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. StartDate string
  191. EdbCode string
  192. EdbType int `description:"指标类型:1:基础指标,2:计算指标"`
  193. Children []*EdbClassifyItems `gorm:"-"`
  194. Button EdbClassifyItemsButton `gorm:"-" description:"操作权限"`
  195. IsJoinPermission int `description:"是否加入权限管控,0:不加入;1:加入;默认:0"`
  196. HaveOperaAuth bool `description:"是否有数据权限"`
  197. }
  198. type EdbClassifyIdItems struct {
  199. ClassifyId int `description:"分类id"`
  200. ClassifyName string
  201. ClassifyNameEn string
  202. UniqueCode string `description:"唯一编码"`
  203. ParentId int `description:"父级分类id"`
  204. Level int `description:"层级"`
  205. RootId int `description:"顶级分类id"`
  206. IsJoinPermission int `description:"是否加入权限管控,0:不加入;1:加入;默认:0" json:"-"`
  207. HaveOperaAuth bool `description:"是否有该数据权限,默认:false"`
  208. }
  209. type EdbClassifyItemList []*EdbClassifyItems
  210. func (m EdbClassifyItemList) Len() int {
  211. return len(m)
  212. }
  213. func (m EdbClassifyItemList) Less(i, j int) bool {
  214. return m[i].Sort < m[j].Sort
  215. }
  216. func (m EdbClassifyItemList) Swap(i, j int) {
  217. m[i], m[j] = m[j], m[i]
  218. }
  219. // EdbClassifyItemsButton 操作按钮
  220. type EdbClassifyItemsButton struct {
  221. AddButton bool `description:"是否可添加"`
  222. OpButton bool `description:"是否可编辑"`
  223. DeleteButton bool `description:"是否可删除"`
  224. MoveButton bool `description:"是否可移动"`
  225. ShowEdbRelation bool `description:"是否展示关联指标"`
  226. ShowChartRelation bool `description:"是否展示关联图表"`
  227. InsertNewDataButton bool `description:"是否可插入最新值"`
  228. }
  229. type EdbClassifyListResp struct {
  230. AllNodes EdbClassifyItemList
  231. CanOpClassify bool `description:"是否允许操作分类"`
  232. Language string `description:"指标的展示语言,CN:中文,EN:英文"`
  233. }
  234. type ClassifyDeleteCheckResp struct {
  235. DeleteStatus int `description:"检测状态:0:默认值,如果为0,继续走其他校验,1:若目录关联指标不可删除,2:确认删除当前目录及包含的子目录吗,3:当前指标已用作画图,不可删除"`
  236. TipsMsg string `description:"提示信息"`
  237. TableList []*ExcelBaseInfo `description:"关联的表格"`
  238. }
  239. type ExcelBaseInfo struct {
  240. ExcelInfoId int `orm:"column(excel_info_id);pk" gorm:"primaryKey" `
  241. Source int `description:"表格来源,1:excel插件的表格,2:自定义表格,3:混合表格,4:自定义分析,默认:1"`
  242. ExcelType int `description:"表格类型,1:指标列,2:日期列,默认:1"`
  243. ExcelName string `description:"表格名称"`
  244. UniqueCode string `description:"表格唯一编码"`
  245. ExcelClassifyId int `description:"表格分类id"`
  246. //SysUserId int `description:"操作人id"`
  247. //SysUserRealName string `description:"操作人真实姓名"`
  248. }
  249. type ClassifyDeleteCheckReq struct {
  250. ClassifyId int `description:"分类id"`
  251. EdbInfoId int `description:"指标id"`
  252. }
  253. func GetClassifyCountByClassifyId(classifyId int) (count int, err error) {
  254. o := global.DmSQL["data"]
  255. sql := `WITH RECURSIVE classify_cte(classify_id, parent_id) AS (
  256. SELECT classify_id, parent_id
  257. FROM edb_classify
  258. WHERE parent_id = ?
  259. UNION ALL
  260. SELECT e.classify_id, e.parent_id
  261. FROM edb_classify e
  262. INNER JOIN classify_cte c ON e.parent_id = c.classify_id
  263. )
  264. SELECT COUNT(1) AS COUNT
  265. FROM classify_cte
  266. WHERE classify_id <> ? ;`
  267. err = o.Raw(sql, classifyId, classifyId).Scan(&count).Error
  268. return
  269. }
  270. type EdbClassifySimplify struct {
  271. ClassifyId int `description:"分类id"`
  272. ClassifyName string `description:"分类名称"`
  273. ParentId int
  274. }
  275. // 递归获取所有目录
  276. func GetClassifyAllByClassifyId(classifyId int) (resultList []*EdbClassifySimplify, err error) {
  277. for {
  278. sql := ` SELECT * FROM edb_classify AS a
  279. WHERE a.classify_id=? order by sort asc,classify_id asc`
  280. item := new(EdbClassifySimplify)
  281. err = global.DmSQL["data"].Raw(sql, classifyId).Scan(&item).Error
  282. if err != nil {
  283. break
  284. }
  285. if item.ClassifyId > 0 {
  286. resultList = append(resultList, item)
  287. classifyId = item.ParentId
  288. } else {
  289. break
  290. }
  291. }
  292. return resultList, err
  293. }
  294. // MoveEdbClassifyReq 移动分类请求参数
  295. type MoveEdbClassifyReq struct {
  296. ClassifyId int `description:"分类id"`
  297. ParentClassifyId int `description:"父级分类id"`
  298. PrevClassifyId int `description:"上一个兄弟节点分类id"`
  299. NextClassifyId int `description:"下一个兄弟节点分类id"`
  300. EdbInfoId int `description:"指标ID, 如果指标ID有值,则移动对象为指标,否则认为移动对象为分类"`
  301. PrevEdbInfoId int `description:"上一个指标ID"`
  302. NextEdbInfoId int `description:"下一个指标ID"`
  303. ClassifyType int `description:"分类类型:0-指标库;2-计算指标"`
  304. }
  305. // GetFirstEdbClassifyByParentId 获取当前父级分类下,且排序数相同 的排序第一条的数据
  306. func GetFirstEdbClassifyByParentId(parentId int) (item *EdbClassify, err error) {
  307. o := global.DmSQL["data"]
  308. sql := ` SELECT * FROM edb_classify WHERE parent_id=? order by sort asc,classify_id asc limit 1`
  309. err = o.Raw(sql, parentId).First(&item).Error
  310. return
  311. }
  312. // UpdateEdbClassifySortByParentId 根据父类id更新排序
  313. func UpdateEdbClassifySortByParentId(parentId, classifyId, nowSort int, updateSort string, classifyType uint8) (err error) {
  314. sql := ` update edb_classify set sort = ` + updateSort + ` WHERE parent_id=? AND sort > ? AND classify_type = ? `
  315. if classifyId > 0 {
  316. sql += ` or ( classify_id > ` + fmt.Sprint(classifyId) + ` and sort = ` + fmt.Sprint(nowSort) + `)`
  317. }
  318. err = global.DmSQL["data"].Exec(sql, parentId, nowSort, classifyType).Error
  319. return
  320. }
  321. // Update 更新分类基础信息
  322. func (edbClassify *EdbClassify) Update(cols []string) (err error) {
  323. err = global.DmSQL["data"].Select(cols).Updates(edbClassify).Error
  324. return
  325. }
  326. // GetEdbClassifyMaxSort 获取分类下最大的排序数
  327. func GetEdbClassifyMaxSort(parentId int, classifyType uint8) (sort int, err error) {
  328. sql := `SELECT COALESCE(Max(sort), 0) AS sort FROM edb_classify WHERE parent_id=? AND classify_type=? `
  329. err = global.DmSQL["data"].Raw(sql, parentId, classifyType).Scan(&sort).Error
  330. return
  331. }
  332. // GetEdbInfoMaxSortByClassifyId 获取分类下指标的最大的排序数
  333. func GetEdbInfoMaxSortByClassifyId(classifyId int) (sort int, err error) {
  334. sql := `SELECT COALESCE(Max(sort), 0) AS sort FROM edb_info WHERE classify_id=? `
  335. err = global.DmSQL["data"].Raw(sql, classifyId).Scan(&sort).Error
  336. return
  337. }
  338. type ClassifyEdbInfoListResp struct {
  339. EdbInfoList []*EdbClassifyItems
  340. }
  341. // GetEdbClassifyAllV2 获取普通指标的分类列表
  342. func GetEdbClassifyAllV2(classifyType int8) (items []*EdbClassifyItems, err error) {
  343. sql := ` SELECT * FROM edb_classify WHERE parent_id <>0 AND classify_type = ? order by sort asc,classify_id asc`
  344. err = global.DmSQL["data"].Raw(sql, classifyType).Scan(&items).Error
  345. return
  346. }
  347. func GetEdbClassifyByParentIdTwo(classifyType int8) (items []*EdbClassifyItems, err error) {
  348. sql := ` SELECT * FROM edb_classify WHERE level=2 AND classify_type = ? order by sort asc,classify_id asc`
  349. err = global.DmSQL["data"].Raw(sql, classifyType).Scan(&items).Error
  350. return
  351. }
  352. type AddEdbClassifyReqV2 struct {
  353. ClassifyName string `description:"分类名称"`
  354. ParentId int `description:"父级id,第一级传0"`
  355. Level int `description:"层级,第一级传0,其余传上一级的层级"`
  356. ClassifyType uint8 `description:"分类类型,0:普通指标分类,1:预测指标分类"`
  357. }
  358. // GetEdbClassifyMaxSortV2 获取分类下最大的排序数
  359. func GetEdbClassifyMaxSortV2(parentId int, classifyType uint8) (sort int, err error) {
  360. sql := `SELECT COALESCE(MAX(sort), 0) AS sort FROM edb_classify WHERE parent_id=? AND parent_id_two=? AND classify_type=? `
  361. err = global.DmSQL["data"].Raw(sql, parentId, classifyType).Scan(&sort).Error
  362. return
  363. }
  364. func GetEdbClassifyByLevel(level, source int) (items []*EdbClassifyItems, err error) {
  365. sql := ` SELECT * FROM edb_classify WHERE level=? AND classify_type = ? `
  366. err = global.DmSQL["data"].Raw(sql, level, source).Scan(&items).Error
  367. return
  368. }
  369. func FIXEdbClassifyId(newId, oldId int) (err error) {
  370. sql := ` UPDATE edb_info SET classify_id=? WHERE classify_id=? `
  371. err = global.DmSQL["data"].Exec(sql, newId, oldId).Error
  372. return
  373. }
  374. func EditEdbClassifySysUser(classifyId, sysUserId int, chartClassifyName string) (err error) {
  375. sql := `UPDATE edb_classify SET sys_user_id=?,sys_user_real_name=?,modify_time=NOW() WHERE parent_id=? AND level=3 `
  376. err = global.DmSQL["data"].Exec(sql, sysUserId, chartClassifyName, classifyId).Error
  377. return
  378. }
  379. func UpdateEdbClassifyChildByParentClassifyId(classifyIds []int, rootId int, levelStep int) (err error) {
  380. var pars []interface{}
  381. pars = append(pars, rootId, levelStep)
  382. pars = append(pars, classifyIds)
  383. // 更新相关联的二级分类的parentId,和classify_name_second
  384. sql := `update edb_classify
  385. SET root_id = ?, level = level+?
  386. where classify_id IN (` + utils.GetOrmInReplace(len(classifyIds)) + `)`
  387. err = global.DmSQL["data"].Exec(sql, pars...).Error
  388. if err != nil {
  389. return
  390. }
  391. return
  392. }
  393. // GetEdbClassifyByParentIdAndName 根据父级ID和名称获取分类
  394. func GetEdbClassifyByParentIdAndName(parentId int, classifyName string, classifyId int, classifyType uint8) (item *EdbClassify, err error) {
  395. sql := `SELECT * FROM edb_classify WHERE parent_id = ? AND classify_name = ? AND classify_id <> ? and classify_type=? LIMIT 1`
  396. err = global.DmSQL["data"].Raw(sql, parentId, classifyName, classifyId, classifyType).First(&item).Error
  397. return
  398. }
  399. // GetEdbClassifyByIdList
  400. // @Description: 根据分类id列表获取分类列表
  401. // @author: Roc
  402. // @datetime 2024-03-29 10:30:21
  403. // @param classifyId int
  404. // @return item *EdbClassify
  405. // @return err error
  406. func GetEdbClassifyByIdList(classifyIdList []int) (item []*EdbClassify, err error) {
  407. num := len(classifyIdList)
  408. if num <= 0 {
  409. return
  410. }
  411. sql := `SELECT * FROM edb_classify WHERE classify_id in (` + utils.GetOrmInReplace(num) + `) `
  412. err = global.DmSQL["data"].Raw(sql, classifyIdList).Scan(&item).Error
  413. return
  414. }
  415. // GetEdbClassifyByClassifyTypeAndIsJoinPermission
  416. // @Description: 根据分类类型和是否涉密获取分类列表
  417. // @author: Roc
  418. // @datetime 2024-03-29 10:30:21
  419. // @param classifyType int
  420. // @param isJoinPermission int
  421. // @return items []*EdbClassify
  422. // @return err error
  423. func GetEdbClassifyByClassifyTypeAndIsJoinPermission(classifyType, isJoinPermission int) (items []*EdbClassify, err error) {
  424. sql := `SELECT * FROM edb_classify WHERE classify_type = ? AND is_join_permission = ? `
  425. err = global.DmSQL["data"].Raw(sql, classifyType, isJoinPermission).Scan(&items).Error
  426. return
  427. }
  428. // GetEdbClassifyRootIdsByClassifyIds 获取普通指标的顶级分类列表
  429. func GetEdbClassifyRootIdsByClassifyIds(classifyIds []int) (items []int, err error) {
  430. o := global.DmSQL["data"]
  431. sql := `SELECT distinct root_id FROM edb_classify WHERE classify_type=0 and classify_id in (` + utils.GetOrmInReplace(len(classifyIds)) + `)`
  432. err = o.Raw(sql, classifyIds).Scan(&items).Error
  433. return
  434. }
  435. // GetChildEdbClassifyByClassifyType 根据类型获取非顶级分类
  436. func GetChildEdbClassifyByClassifyType(classifyType int) (items []*EdbClassifyItems, err error) {
  437. o := global.DmSQL["data"]
  438. sql := `SELECT * FROM edb_classify WHERE parent_id <> 0 AND classify_type = ? ORDER BY sort ASC,classify_id ASC`
  439. err = o.Raw(sql, classifyType).Find(&items).Error
  440. return
  441. }
  442. // GetIsJoinPermissionEdbClassifyIdList
  443. // @Description: 获取已经加入指标管控的指标分类id列表
  444. // @param classifyType
  445. // @return list
  446. // @return err
  447. func GetIsJoinPermissionEdbClassifyIdList(classifyType int) (list []int, err error) {
  448. pars := make([]interface{}, 0)
  449. sql := ` SELECT classify_id FROM edb_classify WHERE 1=1 AND is_join_permission = 1 `
  450. if classifyType >= 0 {
  451. sql += ` AND classify_type = ? `
  452. pars = append(pars, classifyType)
  453. }
  454. err = global.DmSQL["data"].Raw(sql, pars...).Scan(&list).Error
  455. return
  456. }
  457. // GetEdbClassifyByClassifyTypes 根据类型IDs获取分类
  458. func GetEdbClassifyByClassifyTypes(classifyTypes []int) (items []*EdbClassifyItems, err error) {
  459. if len(classifyTypes) == 0 {
  460. return
  461. }
  462. o := global.DmSQL["data"]
  463. sql := `SELECT * FROM edb_classify WHERE classify_type IN (?) ORDER BY classify_type ASC, sort ASC, classify_id ASC`
  464. err = o.Raw(sql, classifyTypes).Scan(&items).Error
  465. return
  466. }
  467. // UpdateEdbClassifyNameAndNamePath
  468. // @Description: 更新分类名称和子分类的全路径
  469. // @author: Roc
  470. // @receiver edbClassify
  471. // @datetime 2024-11-26 14:39:09
  472. // @param cols []string
  473. // @param oldClassifyNamePath string
  474. // @param newClassifyNamePath string
  475. // @return err error
  476. func (edbClassify *EdbClassify) UpdateEdbClassifyNameAndNamePath(cols []string, oldClassifyNamePath, newClassifyNamePath string) (err error) {
  477. tx := global.DmSQL["data"].Begin()
  478. defer func() {
  479. if err != nil {
  480. _ = tx.Rollback()
  481. return
  482. }
  483. _ = tx.Commit()
  484. }()
  485. // 变更分类信息
  486. err = tx.Select(cols).Updates(edbClassify).Error
  487. if err != nil {
  488. return
  489. }
  490. // 更改子分类的完整的路径
  491. if oldClassifyNamePath != `` && newClassifyNamePath != `` {
  492. sql := `UPDATE edb_classify SET classify_name_path = REPLACE(classify_name_path,?,?) WHERE classify_id_path LIKE ?`
  493. err = tx.Exec(sql, oldClassifyNamePath, newClassifyNamePath, fmt.Sprint(edbClassify.ClassifyIdPath+`,%`)).Error
  494. if err != nil {
  495. return
  496. }
  497. }
  498. return
  499. }
  500. // UpdateEdbClassifyNameAndNamePathByOldClassifyIdPath
  501. // @Description: 根据源分类id全路径更新分类名称和子分类的全路径
  502. // @author: Roc
  503. // @receiver edbClassify
  504. // @datetime 2024-11-26 14:39:09
  505. // @param cols []string
  506. // @param oldClassifyNamePath string
  507. // @param newClassifyNamePath string
  508. // @return err error
  509. func UpdateEdbClassifyNameAndNamePathByOldClassifyIdPath(oldClassifyIdPath, newClassifyIdPath, oldClassifyNamePath, newClassifyNamePath string) (err error) {
  510. // 更改子分类的完整的路径
  511. if oldClassifyIdPath != `` && newClassifyNamePath != `` && newClassifyIdPath != `` {
  512. sql := `UPDATE edb_classify SET classify_id_path = REPLACE(classify_id_path,?,?) ,classify_name_path = REPLACE(classify_name_path,?,?) WHERE classify_id_path LIKE ?`
  513. err = global.DmSQL["data"].Exec(sql, oldClassifyIdPath, newClassifyIdPath, oldClassifyNamePath, newClassifyNamePath, fmt.Sprint(oldClassifyIdPath+`,%`)).Error
  514. if err != nil {
  515. return
  516. }
  517. }
  518. return
  519. }
  520. // UpdateEdbClassify 更新分类基础信息
  521. func UpdateEdbClassify(classifyId int, classifyNamePath, classifyIdPath string) (err error) {
  522. sql := `UPDATE edb_classify SET classify_name_path = ?,classify_id_path = ? WHERE classify_id = ?`
  523. err = global.DmSQL["data"].Exec(sql, classifyNamePath, classifyIdPath, classifyId).Error
  524. return
  525. }