edb_classify.go 23 KB

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