chart_classify.go 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893
  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 := childIds
  447. if len(delIds) == 0 {
  448. delIds = append(delIds, req.ChartClassifyId)
  449. }
  450. err = data_manage.DeleteChartClassifyByIds(delIds)
  451. //err = data_manage.DeleteChartClassify(req.ChartClassifyId)
  452. if err != nil {
  453. br.Msg = "删除失败"
  454. br.ErrMsg = "删除失败,Err:" + err.Error()
  455. return
  456. }
  457. }
  458. resp := new(data_manage.AddChartInfoResp)
  459. //删除图表
  460. if req.ChartInfoId > 0 {
  461. chartInfo, err := data_manage.GetChartInfoById(req.ChartInfoId)
  462. if err != nil {
  463. if utils.IsErrNoRow(err) {
  464. br.Msg = "图表已删除,请刷新页面"
  465. br.ErrMsg = "指标不存在,Err:" + err.Error()
  466. return
  467. } else {
  468. br.Msg = "删除失败"
  469. br.ErrMsg = "删除失败,获取指标信息失败,Err:" + err.Error()
  470. return
  471. }
  472. }
  473. if chartInfo == nil {
  474. br.Msg = "图表已删除,请刷新页面"
  475. return
  476. }
  477. //图表操作权限
  478. ok := data.CheckOpChartPermission(sysUser, chartInfo.SysUserId, true)
  479. if !ok {
  480. br.Msg = "没有该图表的操作权限"
  481. br.ErrMsg = "没有该图表的操作权限"
  482. return
  483. }
  484. // 获取引用该图表的MyCharts, 用于ES删除
  485. var myCond string
  486. var myPars []interface{}
  487. myCond += ` AND a.chart_info_id = ? `
  488. myPars = append(myPars, chartInfo.ChartInfoId)
  489. myCharts, e := data_manage.GetMyChartListGroupByCharyInfoIdAndAdminIdByCondition(myCond, myPars)
  490. if e != nil {
  491. br.Msg = "删除失败"
  492. br.ErrMsg = "获取引用图表的MyChats失败, Err: " + e.Error()
  493. return
  494. }
  495. myIds := make([]int, 0)
  496. for _, m := range myCharts {
  497. myIds = append(myIds, m.MyChartId)
  498. }
  499. source := chartInfo.Source // 区间分析图表(滚动相关性)
  500. //删除图表及关联指标
  501. err = data_manage.DeleteChartInfoAndData(chartInfo.ChartInfoId)
  502. if err != nil {
  503. br.Msg = "删除失败"
  504. br.ErrMsg = "删除失败,Err:" + err.Error()
  505. return
  506. }
  507. // 删除图表系列
  508. chartSeriesOb := new(data_manage.FactorEdbSeriesChartMapping)
  509. seriesMappingItem, e := chartSeriesOb.GetItemByChartInfoId(chartInfo.ChartInfoId)
  510. if e != nil {
  511. if utils.IsErrNoRow(e) {
  512. } else {
  513. br.Msg = "删除失败"
  514. br.ErrMsg = "获取图表关联失败, Err: " + e.Error()
  515. return
  516. }
  517. } else {
  518. factorSeriesOb := new(data_manage.FactorEdbSeries)
  519. e = factorSeriesOb.RemoveSeriesAndMappingByFactorEdbSeriesId(seriesMappingItem)
  520. if e != nil {
  521. br.Msg = "删除失败"
  522. br.ErrMsg = "获取图表关联失败, Err: " + e.Error()
  523. return
  524. }
  525. }
  526. //删除ES
  527. {
  528. go data.EsDeleteChartInfo(chartInfo.ChartInfoId)
  529. // 删除MY ETA 图表 es数据
  530. //go data.EsDeleteMyChartInfoByChartInfoId(chartInfo.ChartInfoId)
  531. go data.EsDeleteMyChartInfoByMyChartIds(myIds)
  532. }
  533. // 删除配置关联指标数据
  534. multiConfig, e := data_manage.GetMultipleGraphConfigChartMappingByChartId(chartInfo.ChartInfoId)
  535. if e != nil && !utils.IsErrNoRow(e) {
  536. br.Msg = "删除失败"
  537. br.ErrMsg = "获取图表关联配置失败, Err: " + e.Error()
  538. return
  539. }
  540. if multiConfig != nil { // 删除配置关联指标数据
  541. e = data_manage.DeleteMultipleGraphConfigByChartInfoId(chartInfo.ChartInfoId, multiConfig.MultipleGraphConfigId, utils.CHART_SOURCE_RANGE_ANALYSIS)
  542. if e != nil {
  543. br.Msg = "删除失败"
  544. br.ErrMsg = "删除图表关联配置失败, Err: " + e.Error()
  545. return
  546. }
  547. }
  548. var condition string
  549. var pars []interface{}
  550. condition += " AND chart_classify_id=? AND source = ? "
  551. pars = append(pars, chartInfo.ChartClassifyId, source)
  552. condition += " AND chart_info_id>? ORDER BY create_time ASC LIMIT 1 "
  553. pars = append(pars, req.ChartInfoId)
  554. nextItem, err := data_manage.GetChartInfoByCondition(condition, pars)
  555. if err != nil && !utils.IsErrNoRow(err) {
  556. br.Msg = "删除失败"
  557. br.ErrMsg = "获取下一级图库信息失败,Err:" + err.Error()
  558. return
  559. }
  560. if nextItem != nil {
  561. resp.UniqueCode = nextItem.UniqueCode
  562. resp.ChartInfoId = nextItem.ChartInfoId
  563. } else {
  564. var condition string
  565. var pars []interface{}
  566. condition += " AND level=1 "
  567. //pars = append(pars, chartInfo.ChartClassifyId)
  568. condition += " AND chart_classify_id>? ORDER BY chart_classify_id ASC LIMIT 1 "
  569. pars = append(pars, chartInfo.ChartClassifyId)
  570. classifyItem, err := data_manage.GetChartClassifyByCondition(condition, pars)
  571. if err != nil && !utils.IsErrNoRow(err) {
  572. br.Msg = "删除失败"
  573. br.ErrMsg = "获取下一级图库分类信息失败,Err:" + err.Error()
  574. return
  575. }
  576. if classifyItem != nil {
  577. nextItem, err = data_manage.GetNextChartInfo(chartInfo.ChartClassifyId)
  578. if err != nil && !utils.IsErrNoRow(err) {
  579. br.Msg = "删除失败"
  580. br.ErrMsg = "获取下一级图库信息失败,Err:" + err.Error()
  581. return
  582. }
  583. if nextItem != nil {
  584. resp.UniqueCode = nextItem.UniqueCode
  585. resp.ChartInfoId = nextItem.ChartInfoId
  586. }
  587. }
  588. }
  589. //新增操作日志
  590. {
  591. chartLog := new(data_manage.ChartInfoLog)
  592. chartLog.ChartName = chartInfo.ChartName
  593. chartLog.ChartInfoId = req.ChartInfoId
  594. chartLog.ChartClassifyId = chartInfo.ChartClassifyId
  595. chartLog.SysUserId = sysUser.AdminId
  596. chartLog.SysUserRealName = sysUser.RealName
  597. chartLog.UniqueCode = chartInfo.UniqueCode
  598. chartLog.CreateTime = time.Now()
  599. chartLog.Content = string(this.Ctx.Input.RequestBody)
  600. chartLog.Status = "删除图表"
  601. chartLog.Method = this.Ctx.Input.URI()
  602. go data_manage.AddChartInfoLog(chartLog)
  603. }
  604. }
  605. br.Ret = 200
  606. br.Msg = "删除成功"
  607. br.Success = true
  608. br.Data = resp
  609. br.IsAddLog = true
  610. }
  611. // ChartClassifyMove
  612. // @Title 区间分析图表分类移动接口
  613. // @Description 区间分析图表分类移动接口
  614. // @Success 200 {object} data_manage.MoveChartClassifyReq
  615. // @router /chart_classify/move [post]
  616. func (this *RangeChartClassifyController) ChartClassifyMove() {
  617. br := new(models.BaseResponse).Init()
  618. defer func() {
  619. if br.ErrMsg == "" {
  620. br.IsSendEmail = false
  621. }
  622. this.Data["json"] = br
  623. this.ServeJSON()
  624. }()
  625. sysUser := this.SysUser
  626. if sysUser == nil {
  627. br.Msg = "请登录"
  628. br.ErrMsg = "请登录,SysUser Is Empty"
  629. br.Ret = 408
  630. return
  631. }
  632. var req data_manage.MoveChartClassifyReq
  633. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  634. if err != nil {
  635. br.Msg = "参数解析异常!"
  636. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  637. return
  638. }
  639. if req.ClassifyId <= 0 && req.ChartInfoId <= 0 {
  640. br.Msg = "参数错误"
  641. br.ErrMsg = "请选择拖动目标,分类目录或者指标"
  642. return
  643. }
  644. err, errMsg := data.MoveChartClassify(req, sysUser, utils.CHART_SOURCE_RANGE_ANALYSIS)
  645. if errMsg != `` {
  646. br.Msg = errMsg
  647. br.ErrMsg = errMsg
  648. if err != nil {
  649. br.ErrMsg = err.Error()
  650. } else {
  651. br.IsSendEmail = false
  652. }
  653. return
  654. }
  655. //if req.ClassifyId <= 0 {
  656. // br.Msg = "参数错误"
  657. // br.ErrMsg = "分类id小于等于0"
  658. // return
  659. //}
  660. //
  661. ////判断分类是否存在
  662. //chartClassifyInfo, err := data_manage.GetChartClassifyById(req.ClassifyId)
  663. //if err != nil {
  664. // br.Msg = "移动失败"
  665. // br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
  666. // return
  667. //}
  668. //if chartClassifyInfo.Source != utils.CHART_SOURCE_RANGE_ANALYSIS {
  669. // br.Msg = "分类异常"
  670. // br.ErrMsg = "分类异常,不是区间分析图表的分类"
  671. // return
  672. //}
  673. //updateCol := make([]string, 0)
  674. //
  675. ////判断上级id是否一致,如果不一致的话,那么需要移动该分类层级
  676. //if chartClassifyInfo.ParentId != req.ParentClassifyId && req.ParentClassifyId != 0 {
  677. // parentChartClassifyInfo, err := data_manage.GetChartClassifyById(req.ParentClassifyId)
  678. // if err != nil {
  679. // br.Msg = "移动失败"
  680. // br.ErrMsg = "获取上级分类信息失败,Err:" + err.Error()
  681. // return
  682. // }
  683. // chartClassifyInfo.ParentId = parentChartClassifyInfo.ChartClassifyId
  684. // chartClassifyInfo.Level = parentChartClassifyInfo.Level + 1
  685. // chartClassifyInfo.ModifyTime = time.Now()
  686. // updateCol = append(updateCol, "ParentId", "Level", "ModifyTime")
  687. //}
  688. //
  689. ////如果有传入 上一个兄弟节点分类id
  690. //if req.PrevClassifyId > 0 {
  691. // //上一个兄弟节点
  692. // prevClassify, err := data_manage.GetChartClassifyById(req.PrevClassifyId)
  693. // if err != nil {
  694. // br.Msg = "移动失败"
  695. // br.ErrMsg = "获取上一个兄弟节点分类信息失败,Err:" + err.Error()
  696. // return
  697. // }
  698. //
  699. // //如果是移动在两个兄弟节点之间
  700. // if req.NextClassifyId > 0 {
  701. // //下一个兄弟节点
  702. // nextClassify, err := data_manage.GetChartClassifyById(req.NextClassifyId)
  703. // if err != nil {
  704. // br.Msg = "移动失败"
  705. // br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  706. // return
  707. // }
  708. // //如果上一个兄弟与下一个兄弟的排序权重是一致的,那么需要将下一个兄弟(以及下个兄弟的同样排序权重)的排序权重+2,自己变成上一个兄弟的排序权重+1
  709. // if prevClassify.Sort == nextClassify.Sort || prevClassify.Sort == chartClassifyInfo.Sort {
  710. // //变更兄弟节点的排序
  711. // updateSortStr := `sort + 2`
  712. // _ = data_manage.UpdateChartClassifySortByParentId(prevClassify.ParentId, prevClassify.ChartClassifyId, prevClassify.Sort, updateSortStr)
  713. // } else {
  714. // //如果下一个兄弟的排序权重正好是上个兄弟节点的下一层,那么需要再加一层了
  715. // if nextClassify.Sort-prevClassify.Sort == 1 {
  716. // //变更兄弟节点的排序
  717. // updateSortStr := `sort + 1`
  718. // _ = data_manage.UpdateChartClassifySortByParentId(prevClassify.ParentId, 0, prevClassify.Sort, updateSortStr)
  719. // }
  720. // }
  721. // }
  722. //
  723. // chartClassifyInfo.Sort = prevClassify.Sort + 1
  724. // chartClassifyInfo.ModifyTime = time.Now()
  725. // updateCol = append(updateCol, "Sort", "ModifyTime")
  726. //
  727. //} else {
  728. // firstClassify, err := data_manage.GetFirstChartClassifyByParentId(chartClassifyInfo.ParentId)
  729. // if err != nil && !utils.IsErrNoRow(err) {
  730. // br.Msg = "移动失败"
  731. // br.ErrMsg = "获取获取当前父级分类下的排序第一条的分类信息失败,Err:" + err.Error()
  732. // return
  733. // }
  734. //
  735. // //如果该分类下存在其他分类,且第一个其他分类的排序等于0,那么需要调整排序
  736. // if firstClassify != nil && firstClassify.Sort == 0 {
  737. // updateSortStr := ` sort + 1 `
  738. // _ = data_manage.UpdateChartClassifySortByParentId(firstClassify.ParentId, firstClassify.ChartClassifyId-1, 0, updateSortStr)
  739. // }
  740. //
  741. // chartClassifyInfo.Sort = 0 //那就是排在第一位
  742. // chartClassifyInfo.ModifyTime = time.Now()
  743. // updateCol = append(updateCol, "Sort", "ModifyTime")
  744. //}
  745. //
  746. ////更新
  747. //if len(updateCol) > 0 {
  748. // err = chartClassifyInfo.Update(updateCol)
  749. // if err != nil {
  750. // br.Msg = "移动失败"
  751. // br.ErrMsg = "修改失败,Err:" + err.Error()
  752. // return
  753. // }
  754. //}
  755. br.Ret = 200
  756. br.Success = true
  757. br.Msg = "移动成功"
  758. }
  759. // ClassifyTree
  760. // @Title 多层分类列表树
  761. // @Description 多层分类列表树
  762. // @Success 200 {object} data_manage.ChartClassifyListResp
  763. // @router /chart_classify/tree [get]
  764. func (this *RangeChartClassifyController) ClassifyTree() {
  765. br := new(models.BaseResponse).Init()
  766. defer func() {
  767. if br.ErrMsg == "" {
  768. br.IsSendEmail = false
  769. }
  770. this.Data["json"] = br
  771. this.ServeJSON()
  772. }()
  773. allList, err := data_manage.GetChartClassifyAllBySource(utils.CHART_SOURCE_RANGE_ANALYSIS)
  774. if err != nil {
  775. br.Msg = "获取失败"
  776. br.ErrMsg = "获取所有分类失败, Err:" + err.Error()
  777. return
  778. }
  779. nodeAll := make([]*data_manage.ChartClassifyItems, 0)
  780. if len(allList) > 0 {
  781. // 已授权分类id
  782. permissionClassifyIdList, e := data_manage_permission.GetUserChartClassifyPermissionList(this.SysUser.AdminId, 0)
  783. if e != nil {
  784. br.Msg = "获取失败"
  785. br.ErrMsg = "获取已授权分类id数据失败,Err:" + e.Error()
  786. return
  787. }
  788. for k, v := range allList {
  789. // 数据权限
  790. v.HaveOperaAuth = data_manage_permission.CheckChartClassifyPermissionByPermissionIdList(v.IsJoinPermission, v.ChartClassifyId, permissionClassifyIdList)
  791. // 按钮权限
  792. button := data.GetChartClassifyOpButton(this.SysUser, v.SysUserId, v.HaveOperaAuth)
  793. allList[k].Button = button
  794. }
  795. nodeAll = data.GetChartClassifyTreeRecursive(allList, 0)
  796. //根据sort值排序
  797. sort.Slice(nodeAll, func(i, j int) bool {
  798. return nodeAll[i].Sort < nodeAll[j].Sort
  799. })
  800. }
  801. language := `CN`
  802. // 显示的语言
  803. {
  804. configDetail, _ := system.GetConfigDetailByCode(this.SysUser.AdminId, system.ChartLanguageVar)
  805. if configDetail != nil {
  806. language = configDetail.ConfigValue
  807. } else {
  808. configDetail, _ = system.GetDefaultConfigDetailByCode(system.ChartLanguageVar)
  809. if configDetail != nil {
  810. language = configDetail.ConfigValue
  811. }
  812. }
  813. }
  814. // 是否允许添加一级分类
  815. canOpClassify := true
  816. button := data.GetChartClassifyOpButton(this.SysUser, 0, true)
  817. if !button.AddButton {
  818. canOpClassify = false
  819. }
  820. resp := new(data_manage.ChartClassifyListResp)
  821. resp.AllNodes = nodeAll
  822. resp.Language = language
  823. resp.CanOpClassify = canOpClassify
  824. br.Ret = 200
  825. br.Success = true
  826. br.Msg = "获取成功"
  827. br.Data = resp
  828. }