chart_classify.go 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890
  1. package range_analysis
  2. import (
  3. "encoding/json"
  4. "eta_gn/eta_api/controllers"
  5. "eta_gn/eta_api/models"
  6. "eta_gn/eta_api/models/data_manage"
  7. "eta_gn/eta_api/models/system"
  8. "eta_gn/eta_api/services/data"
  9. "eta_gn/eta_api/services/data/data_manage_permission"
  10. "eta_gn/eta_api/utils"
  11. "fmt"
  12. "sort"
  13. "time"
  14. )
  15. // RangeChartClassifyController 区间分析图表
  16. type RangeChartClassifyController struct {
  17. controllers.BaseAuthController
  18. }
  19. // ChartClassifyList
  20. // @Title 区间分析图表分类列表
  21. // @Description 区间分析图表分类列表接口
  22. // @Param IsShowMe query bool false "是否只看我的,true、false"
  23. // @Param ParentId query bool false "父级ID"
  24. // @Param Source query int false "图表类型,3:相关性,4:滚动相关性"
  25. // @Success 200 {object} data_manage.ChartClassifyListResp
  26. // @router /chart_classify/list [get]
  27. func (this *RangeChartClassifyController) ChartClassifyList() {
  28. br := new(models.BaseResponse).Init()
  29. defer func() {
  30. if br.ErrMsg == "" {
  31. br.IsSendEmail = false
  32. }
  33. this.Data["json"] = br
  34. this.ServeJSON()
  35. }()
  36. resp := new(data_manage.ChartClassifyListResp)
  37. // 获取当前账号的不可见指标
  38. //noPermissionChartIdMap := make(map[int]bool)
  39. //{
  40. // obj := data_manage.EdbInfoNoPermissionAdmin{}
  41. // confList, err := obj.GetAllChartListByAdminId(this.SysUser.AdminId)
  42. // if err != nil && !utils.IsErrNoRow(err) {
  43. // br.Msg = "获取失败"
  44. // br.ErrMsg = "获取不可见指标配置数据失败,Err:" + err.Error()
  45. // return
  46. // }
  47. // for _, v := range confList {
  48. // noPermissionChartIdMap[v.ChartInfoId] = true
  49. // }
  50. //}
  51. isShowMe, _ := this.GetBool("IsShowMe")
  52. parentId, _ := this.GetInt("ParentId")
  53. source, _ := this.GetInt("Source", utils.CHART_SOURCE_RANGE_ANALYSIS)
  54. nodeAll := make([]*data_manage.ChartClassifyItems, 0)
  55. // 查询分类节点
  56. rootList, err := data_manage.GetChartClassifyByParentId(parentId, utils.CHART_SOURCE_RANGE_ANALYSIS)
  57. if err != nil && !utils.IsErrNoRow(err) {
  58. br.Msg = "获取失败"
  59. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  60. return
  61. }
  62. if len(rootList) > 0 {
  63. permissionClassifyIdList, e := data_manage_permission.GetUserChartClassifyPermissionList(this.SysUser.AdminId, 0)
  64. if e != nil {
  65. br.Msg = "获取失败"
  66. br.ErrMsg = "获取已授权分类id数据失败,Err:" + e.Error()
  67. return
  68. }
  69. for _, v := range rootList {
  70. // 操作按钮权限
  71. v.HaveOperaAuth = data_manage_permission.CheckChartClassifyPermissionByPermissionIdList(v.IsJoinPermission, v.ChartClassifyId, permissionClassifyIdList)
  72. button := data.GetChartClassifyOpButton(this.SysUser, v.SysUserId, v.HaveOperaAuth)
  73. v.Button = button
  74. v.ParentId = parentId
  75. v.Children = make([]*data_manage.ChartClassifyItems, 0)
  76. nodeAll = append(nodeAll, v)
  77. }
  78. }
  79. // 查询图表节点, ParentId=0时说明仅查询一级目录节点
  80. if parentId > 0 {
  81. // 查询当前分类信息
  82. currClassify, e := data_manage.GetChartClassifyById(parentId)
  83. if e != nil {
  84. br.Msg = "获取失败"
  85. br.ErrMsg = "获取当前分类信息失败,Err:" + e.Error()
  86. return
  87. }
  88. // 获取所有有权限的指标和分类
  89. permissionEdbIdList, permissionClassifyIdList, e := data_manage_permission.GetUserChartAndClassifyPermissionList(this.SysUser.AdminId, 0, 0)
  90. if e != nil {
  91. br.Msg = "获取失败"
  92. br.ErrMsg = "获取所有有权限的指标和分类失败,Err:" + e.Error()
  93. return
  94. }
  95. var adminId int
  96. if isShowMe {
  97. adminId = this.SysUser.AdminId
  98. }
  99. charts, e := data_manage.GetChartInfoBySourceAndParentId(source, parentId, adminId)
  100. if e != nil {
  101. br.Msg = "获取失败"
  102. br.ErrMsg = fmt.Sprintf("获取图表信息失败, Err: %v", e)
  103. return
  104. }
  105. for _, v := range charts {
  106. // 操作按钮权限
  107. v.HaveOperaAuth = data_manage_permission.CheckChartPermissionByPermissionIdList(v.IsJoinPermission, currClassify.IsJoinPermission, v.ChartInfoId, v.ChartClassifyId, permissionEdbIdList, permissionClassifyIdList)
  108. button := data.GetChartOpButton(this.SysUser, v.SysUserId, v.HaveOperaAuth)
  109. button.AddButton = false //不管有没有权限,图表都是没有添加按钮的
  110. v.Button = button
  111. v.ParentId = parentId
  112. v.Children = make([]*data_manage.ChartClassifyItems, 0)
  113. nodeAll = append(nodeAll, v)
  114. }
  115. }
  116. // 整体排序
  117. if len(nodeAll) > 0 {
  118. sort.Slice(nodeAll, func(i, j int) bool {
  119. return nodeAll[i].Sort < nodeAll[j].Sort
  120. })
  121. }
  122. resp.AllNodes = nodeAll
  123. br.Ret = 200
  124. br.Success = true
  125. br.Msg = "获取成功"
  126. br.Data = resp
  127. }
  128. // getChartClassifyListForMe 获取我创建的图表
  129. func getChartClassifyListForMe(adminInfo system.Admin, resp *data_manage.ChartClassifyListResp) (errMsg string, err error) {
  130. rootList, err := data_manage.GetChartClassifyByParentId(0, utils.CHART_SOURCE_RANGE_ANALYSIS)
  131. if err != nil && !utils.IsErrNoRow(err) {
  132. errMsg = "获取失败"
  133. return
  134. }
  135. classifyAll, err := data_manage.GetChartClassifyAll(utils.CHART_SOURCE_RANGE_ANALYSIS)
  136. if err != nil && !utils.IsErrNoRow(err) {
  137. errMsg = "获取失败"
  138. return
  139. }
  140. allChartInfo, err := data_manage.GetChartInfoByAdminId([]int{utils.CHART_SOURCE_RANGE_ANALYSIS, utils.CHART_SOURCE_RANGE_ANALYSIS}, adminInfo.AdminId)
  141. if err != nil && !utils.IsErrNoRow(err) {
  142. errMsg = "获取失败"
  143. return
  144. }
  145. chartInfoMap := make(map[int][]*data_manage.ChartClassifyItems)
  146. for _, v := range allChartInfo {
  147. chartInfoMap[v.ChartClassifyId] = append(chartInfoMap[v.ChartClassifyId], v)
  148. }
  149. rootChildMap := make(map[int][]*data_manage.ChartClassifyItems)
  150. for _, v := range classifyAll {
  151. rootChildMap[v.ParentId] = append(rootChildMap[v.ParentId], v)
  152. if existItems, ok := chartInfoMap[v.ChartClassifyId]; ok {
  153. v.Children = existItems
  154. } else {
  155. items := make([]*data_manage.ChartClassifyItems, 0)
  156. v.Children = items
  157. }
  158. }
  159. nodeAll := make([]*data_manage.ChartClassifyItems, 0)
  160. for _, v := range rootList {
  161. if existItems, ok := rootChildMap[v.ChartClassifyId]; ok {
  162. v.Children = existItems
  163. } else {
  164. items := make([]*data_manage.ChartClassifyItems, 0)
  165. v.Children = items
  166. }
  167. nodeAll = append(nodeAll, v)
  168. }
  169. resp.AllNodes = nodeAll
  170. return
  171. }
  172. // ChartClassifyItems
  173. // @Title 获取所有区间分析图表分类接口-不包含图表
  174. // @Description 获取所有区间分析图表分类接口-不包含图表
  175. // @Success 200 {object} data_manage.ChartClassifyListResp
  176. // @router /chart_classify/items [get]
  177. func (this *RangeChartClassifyController) ChartClassifyItems() {
  178. br := new(models.BaseResponse).Init()
  179. defer func() {
  180. this.Data["json"] = br
  181. this.ServeJSON()
  182. }()
  183. rootList, err := data_manage.GetChartClassifyByParentId(0, utils.CHART_SOURCE_RANGE_ANALYSIS)
  184. if err != nil {
  185. br.Msg = "获取失败"
  186. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  187. return
  188. }
  189. nodeAll := make([]*data_manage.ChartClassifyItems, 0)
  190. for k := range rootList {
  191. rootNode := rootList[k]
  192. nodeAll = append(nodeAll, rootNode)
  193. }
  194. resp := new(data_manage.ChartClassifyListResp)
  195. resp.AllNodes = nodeAll
  196. br.Ret = 200
  197. br.Success = true
  198. br.Msg = "获取成功"
  199. br.Data = resp
  200. }
  201. // AddChartClassify
  202. // @Title 新增区间分析图表分类
  203. // @Description 新增区间分析图表分类接口
  204. // @Param request body data_manage.AddChartClassifyReq true "type json string"
  205. // @Success 200 Ret=200 保存成功
  206. // @router /chart_classify/add [post]
  207. func (this *RangeChartClassifyController) AddChartClassify() {
  208. br := new(models.BaseResponse).Init()
  209. defer func() {
  210. this.Data["json"] = br
  211. this.ServeJSON()
  212. }()
  213. var req data_manage.AddChartClassifyReq
  214. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  215. if err != nil {
  216. br.Msg = "参数解析异常!"
  217. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  218. return
  219. }
  220. if req.ChartClassifyName == "" {
  221. br.Msg = "请输入分类名称"
  222. br.IsSendEmail = false
  223. return
  224. }
  225. if req.ParentId < 0 {
  226. br.Msg = "参数错误"
  227. br.IsSendEmail = false
  228. return
  229. }
  230. // 新增图表分类
  231. _, err, errMsg, isSendEmail := data.AddChartClassify(req.ChartClassifyName, req.ParentId, req.Level, utils.CHART_SOURCE_RANGE_ANALYSIS, this.Lang, this.SysUser)
  232. if err != nil {
  233. br.Msg = errMsg
  234. br.ErrMsg = "添加分类失败,Err:" + err.Error()
  235. br.IsSendEmail = isSendEmail
  236. return
  237. }
  238. br.Ret = 200
  239. br.Msg = "添加成功"
  240. br.Success = true
  241. }
  242. // EditChartClassify
  243. // @Title 修改区间分析图表分类
  244. // @Description 修改区间分析图表分类接口
  245. // @Param request body data_manage.EditChartClassifyReq true "type json string"
  246. // @Success 200 Ret=200 修改成功
  247. // @router /chart_classify/edit [post]
  248. func (this *RangeChartClassifyController) EditChartClassify() {
  249. br := new(models.BaseResponse).Init()
  250. defer func() {
  251. this.Data["json"] = br
  252. this.ServeJSON()
  253. }()
  254. var req data_manage.EditChartClassifyReq
  255. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  256. if err != nil {
  257. br.Msg = "参数解析异常!"
  258. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  259. return
  260. }
  261. if req.ChartClassifyName == "" {
  262. br.Msg = "请输入分类名称"
  263. br.IsSendEmail = false
  264. return
  265. }
  266. if req.ChartClassifyId <= 0 {
  267. br.Msg = "参数错误"
  268. br.IsSendEmail = false
  269. return
  270. }
  271. // 编辑图表分类
  272. _, err, errMsg, isSendEmail := data.EditChartClassify(req.ChartClassifyId, utils.CHART_SOURCE_RANGE_ANALYSIS, req.ChartClassifyName, this.Lang, this.SysUser)
  273. if err != nil {
  274. br.Msg = errMsg
  275. br.ErrMsg = "保存分类失败,Err:" + err.Error()
  276. br.IsSendEmail = isSendEmail
  277. return
  278. }
  279. br.Ret = 200
  280. br.Msg = "修改成功"
  281. br.Success = true
  282. br.IsAddLog = true
  283. }
  284. // DeleteChartClassifyCheck
  285. // @Title 删除图表检测接口
  286. // @Description 删除图表检测接口
  287. // @Param request body data_manage.ChartClassifyDeleteCheckResp true "type json string"
  288. // @Success 200 Ret=200 检测成功
  289. // @router /chart_classify/delete/check [post]
  290. func (this *RangeChartClassifyController) DeleteChartClassifyCheck() {
  291. br := new(models.BaseResponse).Init()
  292. defer func() {
  293. this.Data["json"] = br
  294. this.ServeJSON()
  295. }()
  296. var req data_manage.ChartClassifyDeleteCheckReq
  297. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  298. if err != nil {
  299. br.Msg = "参数解析异常!"
  300. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  301. return
  302. }
  303. if req.ChartClassifyId < 0 && req.ChartInfoId <= 0 {
  304. br.Msg = "参数错误"
  305. br.IsSendEmail = false
  306. return
  307. }
  308. var deleteStatus int
  309. var tipsMsg string
  310. childIds := make([]int, 0)
  311. //删除分类
  312. if req.ChartClassifyId > 0 && req.ChartInfoId == 0 {
  313. //判断区间分析图表分类下,是否含有图表
  314. classifyAll, err := data_manage.GetChartClassifyAllBySource(utils.CHART_SOURCE_RANGE_ANALYSIS)
  315. if err != nil {
  316. br.Msg = "删除失败"
  317. br.ErrMsg = "获取分类数据失败,Err:" + err.Error()
  318. return
  319. }
  320. classifyAllMap := make(map[int]*data_manage.ChartClassifyItems)
  321. for _, v := range classifyAll {
  322. classifyAllMap[v.ChartClassifyId] = v
  323. }
  324. data.GetChartClassifyChildIds(req.ChartClassifyId, classifyAllMap, &childIds)
  325. condition := ``
  326. pars := make([]interface{}, 0)
  327. if len(childIds) > 0 {
  328. ids := utils.IntArr2joinString(childIds, ",")
  329. condition = ` AND chart_classify_id IN (`+ ids +`) `
  330. } else {
  331. condition = ` AND chart_classify_id = ? `
  332. pars = append(pars, req.ChartClassifyId)
  333. }
  334. count, err := data_manage.GetChartInfoCountByCondition(condition, pars)
  335. if err != nil {
  336. br.Msg = "判断图表名称是否存在失败"
  337. br.ErrMsg = "判断图表名称是否存在失败,Err:" + err.Error()
  338. return
  339. }
  340. //count, err := data_manage.GetChartInfoCountByClassifyId(req.ChartClassifyId)
  341. //if err != nil {
  342. // br.Msg = "删除失败"
  343. // br.ErrMsg = "分类下是否含有图表失败,Err:" + err.Error()
  344. // return
  345. //}
  346. if count > 0 {
  347. deleteStatus = 1
  348. tipsMsg = "该分类下关联图表不可删除"
  349. }
  350. }
  351. if deleteStatus != 1 && req.ChartInfoId == 0 {
  352. //classifyCount, err := data_manage.GetChartClassifyCountByClassifyId(req.ChartClassifyId)
  353. //if err != nil && !utils.IsErrNoRow(err) {
  354. // br.Msg = "删除失败"
  355. // br.ErrMsg = "分类下是否含有图表失败,Err:" + err.Error()
  356. // return
  357. //}
  358. if len(childIds) > 0 {
  359. deleteStatus = 2
  360. tipsMsg = "确认删除当前目录及包含的子目录吗"
  361. }
  362. }
  363. if deleteStatus == 0 {
  364. tipsMsg = "可删除,进行删除操作"
  365. }
  366. resp := new(data_manage.ChartClassifyDeleteCheckResp)
  367. resp.DeleteStatus = deleteStatus
  368. resp.TipsMsg = tipsMsg
  369. br.Ret = 200
  370. br.Msg = "检测成功"
  371. br.Success = true
  372. br.Data = resp
  373. }
  374. // DeleteChartClassify
  375. // @Title 删除区间分析图表分类/图表
  376. // @Description 删除区间分析图表分类/图表接口
  377. // @Param request body data_manage.DeleteChartClassifyReq true "type json string"
  378. // @Success 200 Ret=200 删除成功
  379. // @router /chart_classify/delete [post]
  380. func (this *RangeChartClassifyController) DeleteChartClassify() {
  381. br := new(models.BaseResponse).Init()
  382. defer func() {
  383. this.Data["json"] = br
  384. this.ServeJSON()
  385. }()
  386. sysUser := this.SysUser
  387. if sysUser == nil {
  388. br.Msg = "请登录"
  389. br.ErrMsg = "请登录,SysUser Is Empty"
  390. br.Ret = 408
  391. return
  392. }
  393. var req data_manage.DeleteChartClassifyReq
  394. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  395. if err != nil {
  396. br.Msg = "参数解析异常!"
  397. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  398. return
  399. }
  400. if req.ChartClassifyId < 0 && req.ChartInfoId <= 0 {
  401. br.Msg = "参数错误"
  402. br.IsSendEmail = false
  403. return
  404. }
  405. //删除分类
  406. if req.ChartClassifyId > 0 && req.ChartInfoId == 0 {
  407. //判断是否含有指标
  408. childIds := make([]int, 0)
  409. classifyAll, err := data_manage.GetChartClassifyAllBySource(utils.CHART_SOURCE_RANGE_ANALYSIS)
  410. if err != nil {
  411. br.Msg = "删除失败"
  412. br.ErrMsg = "获取分类数据失败,Err:" + err.Error()
  413. return
  414. }
  415. classifyAllMap := make(map[int]*data_manage.ChartClassifyItems)
  416. for _, v := range classifyAll {
  417. classifyAllMap[v.ChartClassifyId] = v
  418. }
  419. data.GetChartClassifyChildIds(req.ChartClassifyId, classifyAllMap, &childIds)
  420. condition := ``
  421. pars := make([]interface{}, 0)
  422. if len(childIds) > 0 {
  423. ids := utils.IntArr2joinString(childIds, ",")
  424. condition = ` AND chart_classify_id IN (`+ ids +`) `
  425. } else {
  426. condition = ` AND chart_classify_id = ? `
  427. pars = append(pars, req.ChartClassifyId)
  428. }
  429. count, err := data_manage.GetChartInfoCountByCondition(condition, pars)
  430. if err != nil {
  431. br.Msg = "判断图表名称是否存在失败"
  432. br.ErrMsg = "判断图表名称是否存在失败,Err:" + err.Error()
  433. return
  434. }
  435. //count, err := data_manage.GetChartInfoCountByClassifyId(req.ChartClassifyId)
  436. //if err != nil && !utils.IsErrNoRow(err) {
  437. // br.Msg = "删除失败"
  438. // br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
  439. // return
  440. //}
  441. if count > 0 {
  442. br.Msg = "该目录下存在关联指标,不可删除"
  443. br.IsSendEmail = false
  444. return
  445. }
  446. delIds := append(childIds, req.ChartClassifyId)
  447. err = data_manage.DeleteChartClassifyByIds(delIds)
  448. //err = data_manage.DeleteChartClassify(req.ChartClassifyId)
  449. if err != nil {
  450. br.Msg = "删除失败"
  451. br.ErrMsg = "删除失败,Err:" + err.Error()
  452. return
  453. }
  454. }
  455. resp := new(data_manage.AddChartInfoResp)
  456. //删除图表
  457. if req.ChartInfoId > 0 {
  458. chartInfo, err := data_manage.GetChartInfoById(req.ChartInfoId)
  459. if err != nil {
  460. if utils.IsErrNoRow(err) {
  461. br.Msg = "图表已删除,请刷新页面"
  462. br.ErrMsg = "指标不存在,Err:" + err.Error()
  463. return
  464. } else {
  465. br.Msg = "删除失败"
  466. br.ErrMsg = "删除失败,获取指标信息失败,Err:" + err.Error()
  467. return
  468. }
  469. }
  470. if chartInfo == nil {
  471. br.Msg = "图表已删除,请刷新页面"
  472. return
  473. }
  474. //图表操作权限
  475. ok := data.CheckOpChartPermission(sysUser, chartInfo.SysUserId, true)
  476. if !ok {
  477. br.Msg = "没有该图表的操作权限"
  478. br.ErrMsg = "没有该图表的操作权限"
  479. return
  480. }
  481. // 获取引用该图表的MyCharts, 用于ES删除
  482. var myCond string
  483. var myPars []interface{}
  484. myCond += ` AND a.chart_info_id = ? `
  485. myPars = append(myPars, chartInfo.ChartInfoId)
  486. myCharts, e := data_manage.GetMyChartListGroupByCharyInfoIdAndAdminIdByCondition(myCond, myPars)
  487. if e != nil {
  488. br.Msg = "删除失败"
  489. br.ErrMsg = "获取引用图表的MyChats失败, Err: " + e.Error()
  490. return
  491. }
  492. myIds := make([]int, 0)
  493. for _, m := range myCharts {
  494. myIds = append(myIds, m.MyChartId)
  495. }
  496. source := chartInfo.Source // 区间分析图表(滚动相关性)
  497. //删除图表及关联指标
  498. err = data_manage.DeleteChartInfoAndData(chartInfo.ChartInfoId)
  499. if err != nil {
  500. br.Msg = "删除失败"
  501. br.ErrMsg = "删除失败,Err:" + err.Error()
  502. return
  503. }
  504. // 删除图表系列
  505. chartSeriesOb := new(data_manage.FactorEdbSeriesChartMapping)
  506. seriesMappingItem, e := chartSeriesOb.GetItemByChartInfoId(chartInfo.ChartInfoId)
  507. if e != nil {
  508. if utils.IsErrNoRow(e) {
  509. } else {
  510. br.Msg = "删除失败"
  511. br.ErrMsg = "获取图表关联失败, Err: " + e.Error()
  512. return
  513. }
  514. } else {
  515. factorSeriesOb := new(data_manage.FactorEdbSeries)
  516. e = factorSeriesOb.RemoveSeriesAndMappingByFactorEdbSeriesId(seriesMappingItem)
  517. if e != nil {
  518. br.Msg = "删除失败"
  519. br.ErrMsg = "获取图表关联失败, Err: " + e.Error()
  520. return
  521. }
  522. }
  523. //删除ES
  524. {
  525. go data.EsDeleteChartInfo(chartInfo.ChartInfoId)
  526. // 删除MY ETA 图表 es数据
  527. //go data.EsDeleteMyChartInfoByChartInfoId(chartInfo.ChartInfoId)
  528. go data.EsDeleteMyChartInfoByMyChartIds(myIds)
  529. }
  530. // 删除配置关联指标数据
  531. multiConfig, e := data_manage.GetMultipleGraphConfigChartMappingByChartId(chartInfo.ChartInfoId)
  532. if e != nil && !utils.IsErrNoRow(e) {
  533. br.Msg = "删除失败"
  534. br.ErrMsg = "获取图表关联配置失败, Err: " + e.Error()
  535. return
  536. }
  537. if multiConfig != nil { // 删除配置关联指标数据
  538. e = data_manage.DeleteMultipleGraphConfigByChartInfoId(chartInfo.ChartInfoId, multiConfig.MultipleGraphConfigId, utils.CHART_SOURCE_RANGE_ANALYSIS)
  539. if e != nil {
  540. br.Msg = "删除失败"
  541. br.ErrMsg = "删除图表关联配置失败, Err: " + e.Error()
  542. return
  543. }
  544. }
  545. var condition string
  546. var pars []interface{}
  547. condition += " AND chart_classify_id=? AND source = ? "
  548. pars = append(pars, chartInfo.ChartClassifyId, source)
  549. condition += " AND chart_info_id>? ORDER BY create_time ASC LIMIT 1 "
  550. pars = append(pars, req.ChartInfoId)
  551. nextItem, err := data_manage.GetChartInfoByCondition(condition, pars)
  552. if err != nil && !utils.IsErrNoRow(err) {
  553. br.Msg = "删除失败"
  554. br.ErrMsg = "获取下一级图库信息失败,Err:" + err.Error()
  555. return
  556. }
  557. if nextItem != nil {
  558. resp.UniqueCode = nextItem.UniqueCode
  559. resp.ChartInfoId = nextItem.ChartInfoId
  560. } else {
  561. var condition string
  562. var pars []interface{}
  563. condition += " AND level=1 "
  564. //pars = append(pars, chartInfo.ChartClassifyId)
  565. condition += " AND chart_classify_id>? ORDER BY chart_classify_id ASC LIMIT 1 "
  566. pars = append(pars, chartInfo.ChartClassifyId)
  567. classifyItem, err := data_manage.GetChartClassifyByCondition(condition, pars)
  568. if err != nil && !utils.IsErrNoRow(err) {
  569. br.Msg = "删除失败"
  570. br.ErrMsg = "获取下一级图库分类信息失败,Err:" + err.Error()
  571. return
  572. }
  573. if classifyItem != nil {
  574. nextItem, err = data_manage.GetNextChartInfo(chartInfo.ChartClassifyId)
  575. if err != nil && !utils.IsErrNoRow(err) {
  576. br.Msg = "删除失败"
  577. br.ErrMsg = "获取下一级图库信息失败,Err:" + err.Error()
  578. return
  579. }
  580. if nextItem != nil {
  581. resp.UniqueCode = nextItem.UniqueCode
  582. resp.ChartInfoId = nextItem.ChartInfoId
  583. }
  584. }
  585. }
  586. //新增操作日志
  587. {
  588. chartLog := new(data_manage.ChartInfoLog)
  589. chartLog.ChartName = chartInfo.ChartName
  590. chartLog.ChartInfoId = req.ChartInfoId
  591. chartLog.ChartClassifyId = chartInfo.ChartClassifyId
  592. chartLog.SysUserId = sysUser.AdminId
  593. chartLog.SysUserRealName = sysUser.RealName
  594. chartLog.UniqueCode = chartInfo.UniqueCode
  595. chartLog.CreateTime = time.Now()
  596. chartLog.Content = string(this.Ctx.Input.RequestBody)
  597. chartLog.Status = "删除图表"
  598. chartLog.Method = this.Ctx.Input.URI()
  599. go data_manage.AddChartInfoLog(chartLog)
  600. }
  601. }
  602. br.Ret = 200
  603. br.Msg = "删除成功"
  604. br.Success = true
  605. br.Data = resp
  606. br.IsAddLog = true
  607. }
  608. // ChartClassifyMove
  609. // @Title 区间分析图表分类移动接口
  610. // @Description 区间分析图表分类移动接口
  611. // @Success 200 {object} data_manage.MoveChartClassifyReq
  612. // @router /chart_classify/move [post]
  613. func (this *RangeChartClassifyController) ChartClassifyMove() {
  614. br := new(models.BaseResponse).Init()
  615. defer func() {
  616. if br.ErrMsg == "" {
  617. br.IsSendEmail = false
  618. }
  619. this.Data["json"] = br
  620. this.ServeJSON()
  621. }()
  622. sysUser := this.SysUser
  623. if sysUser == nil {
  624. br.Msg = "请登录"
  625. br.ErrMsg = "请登录,SysUser Is Empty"
  626. br.Ret = 408
  627. return
  628. }
  629. var req data_manage.MoveChartClassifyReq
  630. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  631. if err != nil {
  632. br.Msg = "参数解析异常!"
  633. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  634. return
  635. }
  636. if req.ClassifyId <= 0 && req.ChartInfoId <= 0 {
  637. br.Msg = "参数错误"
  638. br.ErrMsg = "请选择拖动目标,分类目录或者指标"
  639. return
  640. }
  641. err, errMsg := data.MoveChartClassify(req, sysUser, utils.CHART_SOURCE_RANGE_ANALYSIS)
  642. if errMsg != `` {
  643. br.Msg = errMsg
  644. br.ErrMsg = errMsg
  645. if err != nil {
  646. br.ErrMsg = err.Error()
  647. } else {
  648. br.IsSendEmail = false
  649. }
  650. return
  651. }
  652. //if req.ClassifyId <= 0 {
  653. // br.Msg = "参数错误"
  654. // br.ErrMsg = "分类id小于等于0"
  655. // return
  656. //}
  657. //
  658. ////判断分类是否存在
  659. //chartClassifyInfo, err := data_manage.GetChartClassifyById(req.ClassifyId)
  660. //if err != nil {
  661. // br.Msg = "移动失败"
  662. // br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
  663. // return
  664. //}
  665. //if chartClassifyInfo.Source != utils.CHART_SOURCE_RANGE_ANALYSIS {
  666. // br.Msg = "分类异常"
  667. // br.ErrMsg = "分类异常,不是区间分析图表的分类"
  668. // return
  669. //}
  670. //updateCol := make([]string, 0)
  671. //
  672. ////判断上级id是否一致,如果不一致的话,那么需要移动该分类层级
  673. //if chartClassifyInfo.ParentId != req.ParentClassifyId && req.ParentClassifyId != 0 {
  674. // parentChartClassifyInfo, err := data_manage.GetChartClassifyById(req.ParentClassifyId)
  675. // if err != nil {
  676. // br.Msg = "移动失败"
  677. // br.ErrMsg = "获取上级分类信息失败,Err:" + err.Error()
  678. // return
  679. // }
  680. // chartClassifyInfo.ParentId = parentChartClassifyInfo.ChartClassifyId
  681. // chartClassifyInfo.Level = parentChartClassifyInfo.Level + 1
  682. // chartClassifyInfo.ModifyTime = time.Now()
  683. // updateCol = append(updateCol, "ParentId", "Level", "ModifyTime")
  684. //}
  685. //
  686. ////如果有传入 上一个兄弟节点分类id
  687. //if req.PrevClassifyId > 0 {
  688. // //上一个兄弟节点
  689. // prevClassify, err := data_manage.GetChartClassifyById(req.PrevClassifyId)
  690. // if err != nil {
  691. // br.Msg = "移动失败"
  692. // br.ErrMsg = "获取上一个兄弟节点分类信息失败,Err:" + err.Error()
  693. // return
  694. // }
  695. //
  696. // //如果是移动在两个兄弟节点之间
  697. // if req.NextClassifyId > 0 {
  698. // //下一个兄弟节点
  699. // nextClassify, err := data_manage.GetChartClassifyById(req.NextClassifyId)
  700. // if err != nil {
  701. // br.Msg = "移动失败"
  702. // br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  703. // return
  704. // }
  705. // //如果上一个兄弟与下一个兄弟的排序权重是一致的,那么需要将下一个兄弟(以及下个兄弟的同样排序权重)的排序权重+2,自己变成上一个兄弟的排序权重+1
  706. // if prevClassify.Sort == nextClassify.Sort || prevClassify.Sort == chartClassifyInfo.Sort {
  707. // //变更兄弟节点的排序
  708. // updateSortStr := `sort + 2`
  709. // _ = data_manage.UpdateChartClassifySortByParentId(prevClassify.ParentId, prevClassify.ChartClassifyId, prevClassify.Sort, updateSortStr)
  710. // } else {
  711. // //如果下一个兄弟的排序权重正好是上个兄弟节点的下一层,那么需要再加一层了
  712. // if nextClassify.Sort-prevClassify.Sort == 1 {
  713. // //变更兄弟节点的排序
  714. // updateSortStr := `sort + 1`
  715. // _ = data_manage.UpdateChartClassifySortByParentId(prevClassify.ParentId, 0, prevClassify.Sort, updateSortStr)
  716. // }
  717. // }
  718. // }
  719. //
  720. // chartClassifyInfo.Sort = prevClassify.Sort + 1
  721. // chartClassifyInfo.ModifyTime = time.Now()
  722. // updateCol = append(updateCol, "Sort", "ModifyTime")
  723. //
  724. //} else {
  725. // firstClassify, err := data_manage.GetFirstChartClassifyByParentId(chartClassifyInfo.ParentId)
  726. // if err != nil && !utils.IsErrNoRow(err) {
  727. // br.Msg = "移动失败"
  728. // br.ErrMsg = "获取获取当前父级分类下的排序第一条的分类信息失败,Err:" + err.Error()
  729. // return
  730. // }
  731. //
  732. // //如果该分类下存在其他分类,且第一个其他分类的排序等于0,那么需要调整排序
  733. // if firstClassify != nil && firstClassify.Sort == 0 {
  734. // updateSortStr := ` sort + 1 `
  735. // _ = data_manage.UpdateChartClassifySortByParentId(firstClassify.ParentId, firstClassify.ChartClassifyId-1, 0, updateSortStr)
  736. // }
  737. //
  738. // chartClassifyInfo.Sort = 0 //那就是排在第一位
  739. // chartClassifyInfo.ModifyTime = time.Now()
  740. // updateCol = append(updateCol, "Sort", "ModifyTime")
  741. //}
  742. //
  743. ////更新
  744. //if len(updateCol) > 0 {
  745. // err = chartClassifyInfo.Update(updateCol)
  746. // if err != nil {
  747. // br.Msg = "移动失败"
  748. // br.ErrMsg = "修改失败,Err:" + err.Error()
  749. // return
  750. // }
  751. //}
  752. br.Ret = 200
  753. br.Success = true
  754. br.Msg = "移动成功"
  755. }
  756. // ClassifyTree
  757. // @Title 多层分类列表树
  758. // @Description 多层分类列表树
  759. // @Success 200 {object} data_manage.ChartClassifyListResp
  760. // @router /chart_classify/tree [get]
  761. func (this *RangeChartClassifyController) ClassifyTree() {
  762. br := new(models.BaseResponse).Init()
  763. defer func() {
  764. if br.ErrMsg == "" {
  765. br.IsSendEmail = false
  766. }
  767. this.Data["json"] = br
  768. this.ServeJSON()
  769. }()
  770. allList, err := data_manage.GetChartClassifyAllBySource(utils.CHART_SOURCE_RANGE_ANALYSIS)
  771. if err != nil {
  772. br.Msg = "获取失败"
  773. br.ErrMsg = "获取所有分类失败, Err:" + err.Error()
  774. return
  775. }
  776. nodeAll := make([]*data_manage.ChartClassifyItems, 0)
  777. if len(allList) > 0 {
  778. // 已授权分类id
  779. permissionClassifyIdList, e := data_manage_permission.GetUserChartClassifyPermissionList(this.SysUser.AdminId, 0)
  780. if e != nil {
  781. br.Msg = "获取失败"
  782. br.ErrMsg = "获取已授权分类id数据失败,Err:" + e.Error()
  783. return
  784. }
  785. for k, v := range allList {
  786. // 数据权限
  787. v.HaveOperaAuth = data_manage_permission.CheckChartClassifyPermissionByPermissionIdList(v.IsJoinPermission, v.ChartClassifyId, permissionClassifyIdList)
  788. // 按钮权限
  789. button := data.GetChartClassifyOpButton(this.SysUser, v.SysUserId, v.HaveOperaAuth)
  790. allList[k].Button = button
  791. }
  792. nodeAll = data.GetChartClassifyTreeRecursive(allList, 0)
  793. //根据sort值排序
  794. sort.Slice(nodeAll, func(i, j int) bool {
  795. return nodeAll[i].Sort < nodeAll[j].Sort
  796. })
  797. }
  798. language := `CN`
  799. // 显示的语言
  800. {
  801. configDetail, _ := system.GetConfigDetailByCode(this.SysUser.AdminId, system.ChartLanguageVar)
  802. if configDetail != nil {
  803. language = configDetail.ConfigValue
  804. } else {
  805. configDetail, _ = system.GetDefaultConfigDetailByCode(system.ChartLanguageVar)
  806. if configDetail != nil {
  807. language = configDetail.ConfigValue
  808. }
  809. }
  810. }
  811. // 是否允许添加一级分类
  812. canOpClassify := true
  813. button := data.GetChartClassifyOpButton(this.SysUser, 0, true)
  814. if !button.AddButton {
  815. canOpClassify = false
  816. }
  817. resp := new(data_manage.ChartClassifyListResp)
  818. resp.AllNodes = nodeAll
  819. resp.Language = language
  820. resp.CanOpClassify = canOpClassify
  821. br.Ret = 200
  822. br.Success = true
  823. br.Msg = "获取成功"
  824. br.Data = resp
  825. }