edb_classify.go 19 KB

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