chart_info.go 61 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048
  1. package range_analysis
  2. import (
  3. "encoding/json"
  4. "eta/eta_api/controllers"
  5. "eta/eta_api/models"
  6. "eta/eta_api/models/data_manage"
  7. "eta/eta_api/models/data_manage/chart_theme"
  8. "eta/eta_api/models/system"
  9. "eta/eta_api/services/data"
  10. "eta/eta_api/services/data/data_manage_permission"
  11. rangeServ "eta/eta_api/services/data/range_analysis"
  12. "eta/eta_api/utils"
  13. "fmt"
  14. "github.com/rdlucklib/rdluck_tools/paging"
  15. "sort"
  16. "strconv"
  17. "strings"
  18. "time"
  19. )
  20. // RangeChartChartInfoController 区间计算图表管理
  21. type RangeChartChartInfoController struct {
  22. controllers.BaseAuthController
  23. }
  24. // Preview
  25. // @Title 区间计算图表-预览数据
  26. // @Description 区间计算图表-获取预览数据
  27. // @Param StartDate query string true "自定义开始日期"
  28. // @Param EndDate query string true "自定义结束日期"
  29. // @Param LeadValue query int true "领先值"
  30. // @Param LeadUnit query string true "领先单位:年,天,月,季,周"
  31. // @Success 200 {object} data_manage.ChartEdbInfoDetailResp
  32. // @router /chart_info/preview [post]
  33. func (this *RangeChartChartInfoController) Preview() {
  34. br := new(models.BaseResponse).Init()
  35. defer func() {
  36. this.Data["json"] = br
  37. this.ServeJSON()
  38. }()
  39. sysUser := this.SysUser
  40. if sysUser == nil {
  41. br.Msg = "请登录"
  42. br.ErrMsg = "请登录,SysUser Is Empty"
  43. br.Ret = 408
  44. return
  45. }
  46. var req data_manage.ChartRangeAnalysisPreviewReq
  47. if err := json.Unmarshal(this.Ctx.Input.RequestBody, &req); err != nil {
  48. br.Msg = "参数解析异常!"
  49. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  50. return
  51. }
  52. // 基础校验
  53. if len(req.ChartEdbInfoList) == 0 {
  54. br.Msg = "请选择指标"
  55. return
  56. }
  57. err, msg, isSendEmail := rangeServ.CheckChartRangeExtraConfig(req.ExtraConfig)
  58. if err != nil {
  59. br.Msg = msg
  60. br.ErrMsg = err.Error()
  61. br.IsSendEmail = isSendEmail
  62. return
  63. }
  64. // 获取指标信息
  65. //chartInfo.CorrelationLeadUnit = req.LeadUnit
  66. edbInfoMappingList := make([]*data_manage.ChartEdbInfoMapping, 0)
  67. for _, v := range req.ChartEdbInfoList {
  68. edbInfoMapping, e := data_manage.GetChartEdbMappingByEdbInfoId(v.EdbInfoId)
  69. if e != nil {
  70. br.Msg = "获取失败"
  71. br.ErrMsg = "获取区间计算图表, A指标mapping信息失败, Err:" + e.Error()
  72. return
  73. }
  74. if v.EdbAliasName != "" {
  75. edbInfoMapping.EdbAliasName = v.EdbAliasName
  76. }
  77. edbInfoMapping.IsAxis = v.IsAxis
  78. edbInfoMappingList = append(edbInfoMappingList, edbInfoMapping)
  79. }
  80. chartInfo := new(data_manage.ChartInfoView)
  81. chartInfo.ChartType = 1
  82. chartInfo.Source = utils.CHART_SOURCE_RANGE_ANALYSIS
  83. chartTheme, err := chart_theme.GetSystemChartTheme(chartInfo.ChartType)
  84. if err != nil {
  85. br.Msg = "获取失败"
  86. br.ErrMsg = "获取图表主题失败, Err:" + err.Error()
  87. return
  88. }
  89. chartInfo.ChartThemeId = chartTheme.ChartThemeId
  90. chartInfo.ChartThemeStyle = chartTheme.Config
  91. // 获取图表x轴y轴
  92. edbList, xEdbIdValue, dataResp, e := rangeServ.GetChartDataByEdbInfoList(0, req.DateType, req.StartYear, req.StartDate, req.EndDate, edbInfoMappingList, &req.ExtraConfig)
  93. if e != nil {
  94. br.Msg = "获取失败"
  95. br.ErrMsg = "获取区间计算图表, 图表计算值失败, Err:" + e.Error()
  96. return
  97. }
  98. //添加配置信息
  99. if req.ExtraConfig.MultipleGraphConfigId == 0 {
  100. multipleGraphConfig := &data_manage.MultipleGraphConfig{
  101. //MultipleGraphConfigId: 0,
  102. SysUserId: sysUser.AdminId,
  103. SysUserRealName: sysUser.RealName,
  104. ModifyTime: time.Now(),
  105. CreateTime: time.Now(),
  106. }
  107. err = data_manage.AddMultipleGraphConfig(multipleGraphConfig)
  108. if err != nil {
  109. br.Msg = "获取失败"
  110. br.ErrMsg = "新增区间计算图表配置失败, Err: " + err.Error()
  111. return
  112. }
  113. dataResp.MultipleGraphConfigId = multipleGraphConfig.MultipleGraphConfigId
  114. }
  115. resp := new(data_manage.ChartInfoDetailResp)
  116. resp.ChartInfo = chartInfo
  117. resp.EdbInfoList = edbList
  118. resp.XEdbIdValue = xEdbIdValue
  119. resp.DataResp = dataResp
  120. br.Data = resp
  121. br.Ret = 200
  122. br.Success = true
  123. br.Msg = "获取成功"
  124. }
  125. // Add
  126. // @Title 新增图表接口
  127. // @Description 新增图表接口
  128. // @Param request body data_manage.AddChartInfoReq true "type json string"
  129. // @Success 200 {object} data_manage.AddChartInfoResp
  130. // @router /chart_info/add [post]
  131. func (this *RangeChartChartInfoController) Add() {
  132. br := new(models.BaseResponse).Init()
  133. defer func() {
  134. this.Data["json"] = br
  135. this.ServeJSON()
  136. }()
  137. sysUser := this.SysUser
  138. if sysUser == nil {
  139. br.Msg = "请登录"
  140. br.ErrMsg = "请登录,SysUser Is Empty"
  141. br.Ret = 408
  142. return
  143. }
  144. deleteCache := true
  145. cacheKey := "CACHE_CHART_INFO_ADD_" + strconv.Itoa(sysUser.AdminId)
  146. defer func() {
  147. if deleteCache {
  148. _ = utils.Rc.Delete(cacheKey)
  149. }
  150. }()
  151. if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) {
  152. deleteCache = false
  153. br.Msg = "系统处理中,请稍后重试!"
  154. br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(this.Ctx.Input.RequestBody)
  155. return
  156. }
  157. var req data_manage.AddChartInfoReq
  158. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  159. if err != nil {
  160. br.Msg = "参数解析异常!"
  161. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  162. return
  163. }
  164. chartInfo, err, errMsg, isSendEmail := rangeServ.AddChartInfo(req, utils.CHART_SOURCE_RANGE_ANALYSIS, sysUser, this.Lang)
  165. if err != nil {
  166. br.Msg = "保存失败"
  167. if errMsg != `` {
  168. br.Msg = errMsg
  169. }
  170. br.ErrMsg = err.Error()
  171. br.IsSendEmail = isSendEmail
  172. return
  173. }
  174. //新增操作日志
  175. {
  176. chartLog := new(data_manage.ChartInfoLog)
  177. chartLog.ChartInfoId = chartInfo.ChartInfoId
  178. chartLog.ChartName = req.ChartName
  179. chartLog.ChartClassifyId = req.ChartClassifyId
  180. chartLog.SysUserId = sysUser.AdminId
  181. chartLog.SysUserRealName = sysUser.RealName
  182. chartLog.UniqueCode = chartInfo.UniqueCode
  183. chartLog.CreateTime = time.Now()
  184. chartLog.Content = string(this.Ctx.Input.RequestBody)
  185. chartLog.Status = "新增区间计算图表"
  186. chartLog.Method = this.Ctx.Input.URI()
  187. go data_manage.AddChartInfoLog(chartLog)
  188. }
  189. resp := new(data_manage.AddChartInfoResp)
  190. resp.ChartInfoId = chartInfo.ChartInfoId
  191. resp.UniqueCode = chartInfo.UniqueCode
  192. resp.ChartType = chartInfo.ChartType
  193. br.Ret = 200
  194. br.Success = true
  195. br.Msg = "保存成功"
  196. br.Data = resp
  197. br.IsAddLog = true
  198. }
  199. // Edit
  200. // @Title 编辑图表接口
  201. // @Description 编辑图表接口
  202. // @Param request body data_manage.EditChartInfoReq true "type json string"
  203. // @Success Ret=200 保存成功
  204. // @router /chart_info/edit [post]
  205. func (this *RangeChartChartInfoController) Edit() {
  206. br := new(models.BaseResponse).Init()
  207. defer func() {
  208. this.Data["json"] = br
  209. this.ServeJSON()
  210. }()
  211. sysUser := this.SysUser
  212. if sysUser == nil {
  213. br.Msg = "请登录"
  214. br.ErrMsg = "请登录,SysUser Is Empty"
  215. br.Ret = 408
  216. return
  217. }
  218. var req data_manage.EditChartInfoReq
  219. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  220. if err != nil {
  221. br.Msg = "参数解析异常!"
  222. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  223. return
  224. }
  225. chartItem, err, errMsg, isSendEmail := rangeServ.EditChartInfo(req, sysUser, this.Lang)
  226. if err != nil {
  227. br.Msg = "保存失败"
  228. if errMsg != `` {
  229. br.Msg = errMsg
  230. }
  231. br.ErrMsg = err.Error()
  232. br.IsSendEmail = isSendEmail
  233. return
  234. }
  235. resp := new(data_manage.AddChartInfoResp)
  236. resp.ChartInfoId = chartItem.ChartInfoId
  237. resp.UniqueCode = chartItem.UniqueCode
  238. resp.ChartType = req.ChartType
  239. //新增操作日志
  240. {
  241. chartLog := new(data_manage.ChartInfoLog)
  242. chartLog.ChartName = chartItem.ChartName
  243. chartLog.ChartInfoId = req.ChartInfoId
  244. chartLog.ChartClassifyId = chartItem.ChartClassifyId
  245. chartLog.SysUserId = sysUser.AdminId
  246. chartLog.SysUserRealName = sysUser.RealName
  247. chartLog.UniqueCode = chartItem.UniqueCode
  248. chartLog.CreateTime = time.Now()
  249. chartLog.Content = string(this.Ctx.Input.RequestBody)
  250. chartLog.Status = "编辑区间计算图表"
  251. chartLog.Method = this.Ctx.Input.URL()
  252. go data_manage.AddChartInfoLog(chartLog)
  253. }
  254. br.Ret = 200
  255. br.Success = true
  256. br.Msg = "保存成功"
  257. br.Data = resp
  258. br.IsAddLog = true
  259. }
  260. // Detail
  261. // @Title 获取图表详情
  262. // @Description 获取图表详情接口
  263. // @Param ChartInfoId query int true "图表id"
  264. // @Param DateType query int true "日期类型:1:00年至今,2:10年至今,3:15年至今,4:年初至今,5:自定义时间"
  265. // @Param StartDate query string true "自定义开始日期"
  266. // @Param EndDate query string true "自定义结束日期"
  267. // @Param Calendar query string true "公历/农历"
  268. // @Param SeasonStartDate query string true "季节性图开始日期"
  269. // @Param SeasonEndDate query string true "季节性图结束日期"
  270. // @Param EdbInfoId query string true "指标ID,多个用英文逗号隔开"
  271. // @Param ChartType query int true "生成样式:1:曲线图,2:季节性图"
  272. // @Success 200 {object} data_manage.ChartInfoDetailResp
  273. // @router /chart_info/detail [get]
  274. func (this *RangeChartChartInfoController) Detail() {
  275. br := new(models.BaseResponse).Init()
  276. defer func() {
  277. this.Data["json"] = br
  278. this.ServeJSON()
  279. }()
  280. sysUser := this.SysUser
  281. if sysUser == nil {
  282. br.Msg = "请登录"
  283. br.ErrMsg = "请登录,SysUser Is Empty"
  284. br.Ret = 408
  285. return
  286. }
  287. chartInfoId, _ := this.GetInt("ChartInfoId")
  288. if chartInfoId <= 0 {
  289. br.Msg = "参数有误"
  290. return
  291. }
  292. dateType, _ := this.GetInt("DateType")
  293. fmt.Println("dateType:", dateType)
  294. startDate := this.GetString("StartDate")
  295. endDate := this.GetString("EndDate")
  296. startYear, _ := this.GetInt("StartYear")
  297. var err error
  298. chartInfo := new(data_manage.ChartInfoView)
  299. chartInfo, err = data_manage.GetChartInfoViewById(chartInfoId)
  300. if err != nil {
  301. if err.Error() == utils.ErrNoRow() {
  302. br.Msg = "图被删除,请刷新页面"
  303. br.ErrMsg = "图被删除,请刷新页面,Err:" + err.Error()
  304. return
  305. }
  306. br.Msg = "获取失败"
  307. br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
  308. return
  309. }
  310. if dateType <= 0 {
  311. dateType = chartInfo.DateType
  312. }
  313. if startDate == "" {
  314. startDate = chartInfo.StartDate
  315. }
  316. if endDate == "" {
  317. endDate = chartInfo.EndDate
  318. }
  319. if startYear <= 0 {
  320. startYear = chartInfo.StartYear
  321. }
  322. // 获取主题样式
  323. chartTheme, err := data.GetChartThemeConfig(chartInfo.ChartThemeId, utils.CHART_SOURCE_DEFAULT, chartInfo.ChartType)
  324. if err != nil {
  325. br.Msg = "获取失败"
  326. br.ErrMsg = "获取主题信息失败,Err:" + err.Error()
  327. return
  328. }
  329. chartInfo.ChartThemeStyle = chartTheme.Config
  330. chartInfo.ChartThemeId = chartTheme.ChartThemeId
  331. // 获取指标信息
  332. //chartInfo.CorrelationLeadUnit = req.LeadUnit
  333. edbInfoMappingList, err := data_manage.GetChartEdbMappingList(chartInfoId)
  334. if err != nil {
  335. br.Msg = "获取失败"
  336. br.ErrMsg = "获取图表,指标信息失败,Err:" + err.Error()
  337. return
  338. }
  339. // 获取图表数据
  340. if len(edbInfoMappingList) == 0 {
  341. br.Msg = "获取失败"
  342. br.ErrMsg = "图表没有指标,无法计算"
  343. return
  344. }
  345. // 区间计算图表配置校验
  346. var extraConfig data_manage.ChartRangeAnalysisExtraConf
  347. if chartInfo.ExtraConfig == `` {
  348. br.Msg = "配置信息错误"
  349. return
  350. }
  351. err = json.Unmarshal([]byte(chartInfo.ExtraConfig), &extraConfig)
  352. if err != nil {
  353. br.Msg = "配置信息错误"
  354. br.ErrMsg = "图表配置信息错误,Err:" + err.Error()
  355. return
  356. }
  357. // 获取图表x轴y轴
  358. edbList, xEdbIdValue, dataResp, e := rangeServ.GetChartDataByEdbInfoList(chartInfoId, dateType, startYear, startDate, endDate, edbInfoMappingList, &extraConfig)
  359. if e != nil {
  360. br.Msg = "获取失败"
  361. br.ErrMsg = "获取区间计算图表, 图表计算值失败, Err:" + e.Error()
  362. return
  363. }
  364. // 判断是否加入我的图库
  365. if chartInfoId > 0 && chartInfo != nil {
  366. {
  367. var myChartCondition string
  368. var myChartPars []interface{}
  369. myChartCondition += ` AND a.admin_id=? `
  370. myChartPars = append(myChartPars, sysUser.AdminId)
  371. myChartCondition += ` AND a.chart_info_id=? `
  372. myChartPars = append(myChartPars, chartInfo.ChartInfoId)
  373. myChartList, err := data_manage.GetMyChartByCondition(myChartCondition, myChartPars)
  374. if err != nil && err.Error() != utils.ErrNoRow() {
  375. br.Msg = "获取失败"
  376. br.ErrMsg = "获取我的图表信息失败,GetMyChartByCondition,Err:" + err.Error()
  377. return
  378. }
  379. if myChartList != nil && len(myChartList) > 0 {
  380. chartInfo.IsAdd = true
  381. chartInfo.MyChartId = myChartList[0].MyChartId
  382. chartInfo.MyChartClassifyId = myChartList[0].MyChartClassifyId
  383. }
  384. }
  385. }
  386. //图表操作权限
  387. chartInfo.IsEdit = data.CheckOpChartPermission(sysUser, chartInfo.SysUserId, true)
  388. //判断是否需要展示英文标识
  389. chartInfo.IsEnChart = data.CheckIsEnChart(chartInfo.ChartNameEn, edbList[0:1], chartInfo.Source, chartInfo.ChartType)
  390. // todo 中英文处理
  391. chartInfo.UnitEn = extraConfig.DataConvertConf.EnUnit
  392. sourceNameList, sourceNameEnList := data.GetEdbSourceByEdbInfoIdList(edbList)
  393. chartInfo.ChartSource = strings.Join(sourceNameList, ",")
  394. chartInfo.ChartSourceEn = strings.Join(sourceNameEnList, ",")
  395. // 另存为
  396. chartInfo.Button = data_manage.ChartViewButton{
  397. IsEdit: chartInfo.IsEdit,
  398. IsEnChart: chartInfo.IsEnChart,
  399. IsAdd: chartInfo.IsAdd,
  400. IsCopy: chartInfo.IsEdit,
  401. IsSetName: chartInfo.IsSetName,
  402. }
  403. // 指标权限
  404. {
  405. edbClassifyPermissionMap := make(map[int]data_manage_permission.EdbClassifyPermission)
  406. classifyMap := make(map[int]*data_manage.EdbClassify)
  407. // 分类
  408. {
  409. classifyIdList := make([]int, 0)
  410. for _, v := range edbList {
  411. classifyIdList = append(classifyIdList, v.ClassifyId)
  412. }
  413. classifyList, tmpErr := data_manage.GetEdbClassifyByIdList(classifyIdList)
  414. if tmpErr != nil {
  415. br.Msg = "获取失败"
  416. br.ErrMsg = "获取分类列表失败,Err:" + tmpErr.Error()
  417. return
  418. }
  419. for _, v := range classifyList {
  420. classifyMap[v.ClassifyId] = v
  421. }
  422. }
  423. // 遍历到校验map
  424. for _, v := range edbList {
  425. edbClassifyPermissionMap[v.EdbInfoId] = data_manage_permission.EdbClassifyPermission{
  426. ClassifyId: v.ClassifyId,
  427. IsJoinPermission: v.IsJoinPermission,
  428. EdbInfoId: v.EdbInfoId,
  429. }
  430. }
  431. // 获取所有有权限的指标和分类
  432. permissionEdbIdList, permissionClassifyIdList, err := data_manage_permission.GetUserEdbAndClassifyPermissionList(sysUser.AdminId, 0, 0)
  433. if err != nil {
  434. br.Msg = "获取失败"
  435. br.ErrMsg = "获取所有有权限的指标和分类失败,Err:" + err.Error()
  436. return
  437. }
  438. for _, v := range edbList {
  439. // 数据权限
  440. edbItem, ok := edbClassifyPermissionMap[v.EdbInfoId]
  441. if !ok {
  442. continue
  443. }
  444. if currClassify, ok := classifyMap[edbItem.ClassifyId]; ok {
  445. v.HaveOperaAuth = data_manage_permission.CheckEdbPermissionByPermissionIdList(edbItem.IsJoinPermission, currClassify.IsJoinPermission, edbItem.EdbInfoId, edbItem.ClassifyId, permissionEdbIdList, permissionClassifyIdList)
  446. }
  447. }
  448. }
  449. // 图表当前分类的分类树
  450. classifyLevels := make([]string, 0)
  451. {
  452. list, e := data_manage.GetChartClassifyAllBySource(utils.CHART_SOURCE_RANGE_ANALYSIS)
  453. if e != nil {
  454. br.Msg = "获取失败"
  455. br.ErrMsg = fmt.Sprintf("获取图表分类失败, Err: %v", e)
  456. return
  457. }
  458. parents := data.GetChartClassifyParentRecursive(list, chartInfo.ChartClassifyId)
  459. sort.Slice(parents, func(i, j int) bool {
  460. return parents[i].Level < parents[i].Level
  461. })
  462. for _, v := range parents {
  463. classifyLevels = append(classifyLevels, v.UniqueCode)
  464. }
  465. }
  466. resp := new(data_manage.ChartInfoDetailResp)
  467. resp.ChartInfo = chartInfo
  468. resp.EdbInfoList = edbList
  469. resp.XEdbIdValue = xEdbIdValue
  470. resp.DataResp = dataResp
  471. resp.ClassifyLevels = classifyLevels
  472. br.Ret = 200
  473. br.Success = true
  474. br.Msg = "获取成功"
  475. br.Data = resp
  476. }
  477. // DetailFromUniqueCode
  478. // @Title 根据编码获取图表详情
  479. // @Description 根据编码获取图表详情接口
  480. // @Param UniqueCode query int true "图表唯一编码,如果是管理后台访问,传固定字符串:7c69b590249049942070ae9dcd5bf6dc"
  481. // @Param IsCache query bool true "是否走缓存,默认false"
  482. // @Success 200 {object} data_manage.ChartInfoDetailFromUniqueCodeResp
  483. // @router /chart_info/detail/from_unique_code [get]
  484. func (this *RangeChartChartInfoController) DetailFromUniqueCode() {
  485. br := new(models.BaseResponse).Init()
  486. defer func() {
  487. this.Data["json"] = br
  488. this.ServeJSON()
  489. }()
  490. sysUser := this.SysUser
  491. if sysUser == nil {
  492. br.Msg = "请登录"
  493. br.ErrMsg = "请登录,SysUser Is Empty"
  494. br.Ret = 408
  495. return
  496. }
  497. adminId := sysUser.AdminId
  498. uniqueCode := this.GetString("UniqueCode")
  499. if uniqueCode == "" {
  500. br.Msg = "参数错误"
  501. br.ErrMsg = "参数错误,uniqueCode is empty"
  502. return
  503. }
  504. //是否走缓存
  505. isCache, _ := this.GetBool("IsCache")
  506. resp := new(data_manage.ChartInfoDetailFromUniqueCodeResp)
  507. status := true
  508. chartInfo, err := data_manage.GetChartInfoViewByUniqueCode(uniqueCode)
  509. if err != nil {
  510. if err.Error() == utils.ErrNoRow() {
  511. status = false
  512. } else {
  513. br.Msg = "获取失败"
  514. br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
  515. return
  516. }
  517. }
  518. if chartInfo == nil {
  519. status = false
  520. }
  521. if !status {
  522. endInfoList := make([]*data_manage.ChartEdbInfoMapping, 0)
  523. resp.EdbInfoList = endInfoList
  524. resp.ChartInfo = chartInfo
  525. resp.Status = false
  526. br.Ret = 200
  527. br.Success = true
  528. br.Msg = "获取成功"
  529. br.Data = resp
  530. return
  531. }
  532. //判断是否存在缓存,如果存在缓存,那么直接从缓存中获取
  533. key := data.GetChartInfoDataKey(chartInfo.ChartInfoId)
  534. if utils.Re == nil && isCache {
  535. if utils.Re == nil && utils.Rc.IsExist(key) {
  536. if d, e := utils.Rc.RedisBytes(key); e == nil {
  537. err := json.Unmarshal(d, &resp)
  538. if err == nil && resp != nil {
  539. // 这里跟当前用户相关的信息重新查询写入resp, 不使用缓存中的
  540. var myCond string
  541. var myPars []interface{}
  542. myCond += ` AND a.admin_id=? `
  543. myPars = append(myPars, adminId)
  544. myCond += ` AND a.chart_info_id=? `
  545. myPars = append(myPars, chartInfo.ChartInfoId)
  546. myList, err := data_manage.GetMyChartByCondition(myCond, myPars)
  547. if err != nil && err.Error() != utils.ErrNoRow() {
  548. br.Msg = "获取失败"
  549. br.ErrMsg = "获取我的图表信息失败,GetMyChartByCondition,Err:" + err.Error()
  550. return
  551. }
  552. resp.ChartInfo.IsAdd = false
  553. resp.ChartInfo.MyChartId = 0
  554. resp.ChartInfo.MyChartClassifyId = ""
  555. if myList != nil && len(myList) > 0 {
  556. resp.ChartInfo.IsAdd = true
  557. resp.ChartInfo.MyChartId = myList[0].MyChartId
  558. resp.ChartInfo.MyChartClassifyId = myList[0].MyChartClassifyId
  559. }
  560. br.Ret = 200
  561. br.Success = true
  562. br.Msg = "获取成功"
  563. br.Data = resp
  564. return
  565. }
  566. }
  567. }
  568. }
  569. resp, isOk, msg, errMsg := GetChartInfoDetailFromUniqueCode(chartInfo, isCache, sysUser)
  570. if !isOk {
  571. br.Msg = msg
  572. br.ErrMsg = errMsg
  573. return
  574. }
  575. br.Ret = 200
  576. br.Success = true
  577. br.Msg = "获取成功"
  578. br.Data = resp
  579. }
  580. // GetChartInfoDetailFromUniqueCode 根据编码获取图表详情
  581. func GetChartInfoDetailFromUniqueCode(chartInfo *data_manage.ChartInfoView, isCache bool, sysUser *system.Admin) (resp *data_manage.ChartInfoDetailFromUniqueCodeResp, isOk bool, msg, errMsg string) {
  582. resp = new(data_manage.ChartInfoDetailFromUniqueCodeResp)
  583. adminId := sysUser.AdminId
  584. // 指标数据map
  585. edbClassifyPermissionMap := make(map[int]data_manage_permission.EdbClassifyPermission)
  586. defer func() {
  587. if isOk {
  588. // 这里跟当前用户相关的信息重新查询写入resp, 不使用缓存中的
  589. {
  590. //判断是否加入我的图库
  591. var myChartCondition string
  592. var myChartPars []interface{}
  593. myChartCondition += ` AND a.admin_id=? `
  594. myChartPars = append(myChartPars, adminId)
  595. myChartCondition += ` AND a.chart_info_id=? `
  596. myChartPars = append(myChartPars, chartInfo.ChartInfoId)
  597. myChartList, err := data_manage.GetMyChartByCondition(myChartCondition, myChartPars)
  598. if err != nil && err.Error() != utils.ErrNoRow() {
  599. msg = "获取失败"
  600. errMsg = "获取我的图表信息失败,GetMyChartByCondition,Err:" + err.Error()
  601. return
  602. }
  603. if myChartList != nil && len(myChartList) > 0 {
  604. chartInfo.IsAdd = true
  605. chartInfo.MyChartId = myChartList[0].MyChartId
  606. chartInfo.MyChartClassifyId = myChartList[0].MyChartClassifyId
  607. }
  608. }
  609. resp.ChartInfo.HaveOperaAuth = true
  610. // 指标权限
  611. {
  612. classifyMap := make(map[int]*data_manage.EdbClassify)
  613. // 分类
  614. {
  615. classifyIdList := make([]int, 0)
  616. for _, v := range resp.EdbInfoList {
  617. classifyIdList = append(classifyIdList, v.ClassifyId)
  618. }
  619. classifyList, tmpErr := data_manage.GetEdbClassifyByIdList(classifyIdList)
  620. if tmpErr != nil {
  621. errMsg = "获取分类列表失败,Err:" + tmpErr.Error()
  622. return
  623. }
  624. for _, v := range classifyList {
  625. classifyMap[v.ClassifyId] = v
  626. }
  627. }
  628. // 指标
  629. if len(edbClassifyPermissionMap) < 0 {
  630. edbInfoIdList := make([]int, 0)
  631. for _, v := range resp.EdbInfoList {
  632. edbInfoIdList = append(edbInfoIdList, v.EdbInfoId)
  633. }
  634. edbInfoList, tmpErr := data_manage.GetEdbInfoByIdList(edbInfoIdList)
  635. if tmpErr != nil {
  636. errMsg = "获取指标列表失败,Err:" + tmpErr.Error()
  637. return
  638. }
  639. for _, v := range edbInfoList {
  640. edbClassifyPermissionMap[v.EdbInfoId] = data_manage_permission.EdbClassifyPermission{
  641. ClassifyId: v.ClassifyId,
  642. IsJoinPermission: v.IsJoinPermission,
  643. EdbInfoId: v.EdbInfoId,
  644. }
  645. }
  646. }
  647. // 获取所有有权限的指标和分类
  648. permissionEdbIdList, permissionClassifyIdList, err := data_manage_permission.GetUserEdbAndClassifyPermissionList(sysUser.AdminId, 0, 0)
  649. if err != nil {
  650. errMsg = "获取所有有权限的指标和分类失败,Err:" + err.Error()
  651. return
  652. }
  653. for _, v := range resp.EdbInfoList {
  654. // 数据权限
  655. edbItem, ok := edbClassifyPermissionMap[v.EdbInfoId]
  656. if !ok {
  657. continue
  658. }
  659. if currClassify, ok := classifyMap[edbItem.ClassifyId]; ok {
  660. v.HaveOperaAuth = data_manage_permission.CheckEdbPermissionByPermissionIdList(edbItem.IsJoinPermission, currClassify.IsJoinPermission, edbItem.EdbInfoId, edbItem.ClassifyId, permissionEdbIdList, permissionClassifyIdList)
  661. }
  662. }
  663. }
  664. }
  665. }()
  666. //判断是否存在缓存,如果存在缓存,那么直接从缓存中获取
  667. key := data.GetChartInfoDataKey(chartInfo.ChartInfoId)
  668. if utils.Re == nil && isCache {
  669. if utils.Re == nil && utils.Rc.IsExist(key) {
  670. if chartData, err1 := utils.Rc.RedisBytes(key); err1 == nil {
  671. err := json.Unmarshal(chartData, &resp)
  672. if err != nil || resp == nil {
  673. return
  674. }
  675. isOk = true
  676. fmt.Println("source redis")
  677. return
  678. }
  679. }
  680. }
  681. // 获取主题样式
  682. chartTheme, err := data.GetChartThemeConfig(chartInfo.ChartThemeId, utils.CHART_SOURCE_DEFAULT, 1)
  683. if err != nil {
  684. msg = "获取失败"
  685. errMsg = "获取主题信息失败,Err:" + err.Error()
  686. return
  687. }
  688. chartInfo.ChartThemeStyle = chartTheme.Config
  689. chartInfo.ChartThemeId = chartTheme.ChartThemeId
  690. chartInfoId := chartInfo.ChartInfoId
  691. // 获取指标信息
  692. //chartInfo.CorrelationLeadUnit = req.LeadUnit
  693. edbInfoMappingList, err := data_manage.GetChartEdbMappingList(chartInfoId)
  694. if err != nil {
  695. msg = "获取失败"
  696. errMsg = "获取图表,指标信息失败,Err:" + err.Error()
  697. return
  698. }
  699. dateType := chartInfo.DateType
  700. // 开始/结束日期
  701. startYear := chartInfo.StartYear
  702. startDate := chartInfo.StartDate
  703. endDate := chartInfo.EndDate
  704. // 区间计算图表配置校验
  705. var extraConfig data_manage.ChartRangeAnalysisExtraConf
  706. if chartInfo.ExtraConfig == `` {
  707. msg = "配置信息错误"
  708. return
  709. }
  710. err = json.Unmarshal([]byte(chartInfo.ExtraConfig), &extraConfig)
  711. if err != nil {
  712. msg = "配置信息错误"
  713. errMsg = "图表配置信息错误,Err:" + err.Error()
  714. return
  715. }
  716. // 获取图表数据
  717. if len(edbInfoMappingList) == 0 {
  718. msg = "获取失败"
  719. errMsg = "图表没有指标,无法计算"
  720. return
  721. }
  722. // 获取图表x轴y轴
  723. edbList, xEdbIdValue, dataResp, e := rangeServ.GetChartDataByEdbInfoList(chartInfoId, dateType, startYear, startDate, endDate, edbInfoMappingList, &extraConfig)
  724. if e != nil {
  725. msg = "获取失败"
  726. errMsg = "获取区间计算图表, 图表计算值失败, Err:" + e.Error()
  727. return
  728. }
  729. if chartInfoId > 0 && chartInfo != nil {
  730. //判断是否加入我的图库
  731. {
  732. var myChartCondition string
  733. var myChartPars []interface{}
  734. myChartCondition += ` AND a.admin_id=? `
  735. myChartPars = append(myChartPars, sysUser.AdminId)
  736. myChartCondition += ` AND a.chart_info_id=? `
  737. myChartPars = append(myChartPars, chartInfo.ChartInfoId)
  738. myChartList, err := data_manage.GetMyChartByCondition(myChartCondition, myChartPars)
  739. if err != nil && err.Error() != utils.ErrNoRow() {
  740. msg = "获取失败"
  741. errMsg = "获取我的图表信息失败,GetMyChartByCondition,Err:" + err.Error()
  742. return
  743. }
  744. if myChartList != nil && len(myChartList) > 0 {
  745. chartInfo.IsAdd = true
  746. chartInfo.MyChartId = myChartList[0].MyChartId
  747. chartInfo.MyChartClassifyId = myChartList[0].MyChartClassifyId
  748. }
  749. }
  750. }
  751. //图表操作权限
  752. chartInfo.IsEdit = data.CheckOpChartPermission(sysUser, chartInfo.SysUserId, true)
  753. //判断是否需要展示英文标识
  754. chartInfo.IsEnChart = data.CheckIsEnChart(chartInfo.ChartNameEn, edbList[0:1], chartInfo.Source, chartInfo.ChartType)
  755. chartInfo.UnitEn = ""
  756. // 另存为
  757. chartInfo.Button = data_manage.ChartViewButton{
  758. IsEdit: chartInfo.IsEdit,
  759. IsEnChart: chartInfo.IsEnChart,
  760. IsAdd: chartInfo.IsAdd,
  761. IsCopy: chartInfo.IsEdit,
  762. IsSetName: chartInfo.IsSetName,
  763. }
  764. // 图表的指标来源
  765. sourceNameList, sourceNameEnList := data.GetEdbSourceByEdbInfoIdList(edbList)
  766. chartInfo.ChartSource = strings.Join(sourceNameList, ",")
  767. chartInfo.ChartSourceEn = strings.Join(sourceNameEnList, ",")
  768. resp.ChartInfo = chartInfo
  769. resp.EdbInfoList = edbList
  770. resp.XEdbIdValue = xEdbIdValue
  771. resp.DataResp = dataResp
  772. resp.Status = true
  773. // 遍历到校验map
  774. for _, v := range edbList {
  775. edbClassifyPermissionMap[v.EdbInfoId] = data_manage_permission.EdbClassifyPermission{
  776. ClassifyId: v.ClassifyId,
  777. IsJoinPermission: v.IsJoinPermission,
  778. EdbInfoId: v.EdbInfoId,
  779. }
  780. }
  781. // 将数据加入缓存
  782. if utils.Re == nil {
  783. d, _ := json.Marshal(resp)
  784. _ = utils.Rc.Put(key, d, 2*time.Hour)
  785. }
  786. isOk = true
  787. return
  788. }
  789. // List
  790. // @Title 区间计算图表列表接口
  791. // @Description 区间计算图表列表接口
  792. // @Param PageSize query int true "每页数据条数"
  793. // @Param CurrentIndex query int true "当前页页码,从1开始"
  794. // @Param ChartClassifyId query int true "分类id"
  795. // @Param Keyword query string true "搜索关键词"
  796. // @Param IsShowMe query bool true "是否只看我的,true、false"
  797. // @Param Source query int true "图表类型,3:区间计算,4:滚动区间计算"
  798. // @Success 200 {object} data_manage.ChartListResp
  799. // @router /chart_info/list [get]
  800. func (this *RangeChartChartInfoController) List() {
  801. br := new(models.BaseResponse).Init()
  802. defer func() {
  803. this.Data["json"] = br
  804. this.ServeJSON()
  805. }()
  806. sysUser := this.SysUser
  807. if sysUser == nil {
  808. br.Msg = "请登录"
  809. br.ErrMsg = "请登录,SysUser Is Empty"
  810. br.Ret = 408
  811. return
  812. }
  813. chartClassifyId, _ := this.GetInt("ChartClassifyId")
  814. pageSize, _ := this.GetInt("PageSize")
  815. currentIndex, _ := this.GetInt("CurrentIndex")
  816. keyword := this.GetString("KeyWord")
  817. var total int
  818. page := paging.GetPaging(currentIndex, pageSize, total)
  819. var startSize int
  820. if pageSize <= 0 {
  821. pageSize = utils.PageSize20
  822. }
  823. if currentIndex <= 0 {
  824. currentIndex = 1
  825. }
  826. startSize = paging.StartIndex(currentIndex, pageSize)
  827. source := utils.CHART_SOURCE_RANGE_ANALYSIS
  828. var condition string
  829. var pars []interface{}
  830. // 普通图表
  831. condition += ` AND source = ? `
  832. pars = append(pars, source)
  833. if chartClassifyId > 0 {
  834. chartClassifyId, err := data_manage.GetChartClassify(chartClassifyId)
  835. if err != nil && err.Error() != utils.ErrNoRow() {
  836. br.Msg = "获取图表信息失败"
  837. br.ErrMsg = "获取信息失败,GetChartClassify,Err:" + err.Error()
  838. return
  839. }
  840. condition += " AND chart_classify_id IN(" + chartClassifyId + ") "
  841. }
  842. if keyword != "" {
  843. //将关键词按照空格分割
  844. keywords := strings.Split(keyword, " ")
  845. condition += ` AND ( chart_name LIKE '%` + keywords[0] + `%' `
  846. for k, key := range keywords {
  847. if k == 0 {
  848. continue
  849. }
  850. condition += ` OR chart_name LIKE '%` + key + `%' `
  851. }
  852. condition += ` )`
  853. }
  854. //只看我的
  855. isShowMe, _ := this.GetBool("IsShowMe")
  856. if isShowMe {
  857. condition += ` AND sys_user_id = ? `
  858. pars = append(pars, sysUser.AdminId)
  859. }
  860. // 获取当前账号的不可见指标
  861. noPermissionChartIdList := make([]int, 0)
  862. {
  863. obj := data_manage.EdbInfoNoPermissionAdmin{}
  864. confList, err := obj.GetAllChartListByAdminId(this.SysUser.AdminId)
  865. if err != nil && err.Error() != utils.ErrNoRow() {
  866. br.Msg = "获取失败"
  867. br.ErrMsg = "获取不可见指标配置数据失败,Err:" + err.Error()
  868. return
  869. }
  870. for _, v := range confList {
  871. noPermissionChartIdList = append(noPermissionChartIdList, v.ChartInfoId)
  872. }
  873. }
  874. lenNoPermissionChartIdList := len(noPermissionChartIdList)
  875. if lenNoPermissionChartIdList > 0 {
  876. condition += ` AND chart_info_id not in (` + utils.GetOrmInReplace(lenNoPermissionChartIdList) + `) `
  877. pars = append(pars, noPermissionChartIdList)
  878. }
  879. //获取图表信息
  880. list, err := data_manage.GetChartListByCondition(condition, pars, startSize, pageSize)
  881. if err != nil && err.Error() != utils.ErrNoRow() {
  882. br.Success = true
  883. br.Msg = "获取图表信息失败"
  884. br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
  885. return
  886. }
  887. myChartList, err := data_manage.GetMyChartListByAdminId(sysUser.AdminId)
  888. if err != nil && err.Error() != utils.ErrNoRow() {
  889. br.Msg = "获取图表信息失败"
  890. br.ErrMsg = "获取我的图表信息失败,Err:" + err.Error()
  891. return
  892. }
  893. myChartMap := make(map[int]*data_manage.MyChartView)
  894. for _, v := range myChartList {
  895. myChartMap[v.ChartInfoId] = v
  896. }
  897. listLen := len(list)
  898. chartEdbMap := make(map[int][]*data_manage.ChartEdbInfoMapping)
  899. if listLen > 0 {
  900. chartInfoIds := ""
  901. for _, v := range list {
  902. chartInfoIds += strconv.Itoa(v.ChartInfoId) + ","
  903. }
  904. if chartInfoIds != "" {
  905. chartInfoIds = strings.Trim(chartInfoIds, ",")
  906. //判断是否需要展示英文标识
  907. edbList, e := data_manage.GetChartEdbMappingListByChartInfoIds(chartInfoIds)
  908. if e != nil {
  909. br.Msg = "获取失败"
  910. br.ErrMsg = "获取图表,指标信息失败,Err:" + e.Error()
  911. return
  912. }
  913. for _, v := range edbList {
  914. chartEdbMap[v.ChartInfoId] = append(chartEdbMap[v.ChartInfoId], v)
  915. }
  916. }
  917. }
  918. for i := 0; i < listLen; i++ {
  919. //判断是否需要展示英文标识
  920. if edbTmpList, ok := chartEdbMap[list[i].ChartInfoId]; ok {
  921. list[i].IsEnChart = data.CheckIsEnChart(list[i].ChartNameEn, edbTmpList, list[i].Source, list[i].ChartType)
  922. }
  923. if existItem, ok := myChartMap[list[i].ChartInfoId]; ok {
  924. list[i].IsAdd = true
  925. list[i].MyChartId = existItem.MyChartId
  926. list[i].MyChartClassifyId = existItem.MyChartClassifyId
  927. }
  928. }
  929. resp := new(data_manage.ChartListResp)
  930. if list == nil || len(list) <= 0 || (err != nil && err.Error() == utils.ErrNoRow()) {
  931. items := make([]*data_manage.ChartInfoView, 0)
  932. resp.Paging = page
  933. resp.List = items
  934. br.Ret = 200
  935. br.Success = true
  936. br.Msg = "获取成功"
  937. return
  938. }
  939. dataCount, err := data_manage.GetChartListCountByCondition(condition, pars)
  940. if err != nil && err.Error() != utils.ErrNoRow() {
  941. br.Msg = "获取指标信息失败"
  942. br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
  943. return
  944. }
  945. page = paging.GetPaging(currentIndex, pageSize, dataCount)
  946. resp.Paging = page
  947. resp.List = list
  948. br.Ret = 200
  949. br.Success = true
  950. br.Msg = "获取成功"
  951. br.Data = resp
  952. }
  953. // Copy
  954. // @Title 复制并新增图表接口
  955. // @Description 新增图表接口
  956. // @Params request body data_manage.CopyAddChartInfoReq true "type json string"
  957. // @Success 200 {object} data_manage.AddChartInfoResp
  958. // @router /chart_info/copy [post]
  959. func (this *RangeChartChartInfoController) Copy() {
  960. br := new(models.BaseResponse).Init()
  961. defer func() {
  962. if br.ErrMsg == "" {
  963. br.IsSendEmail = false
  964. }
  965. this.Data["json"] = br
  966. this.ServeJSON()
  967. }()
  968. sysUser := this.SysUser
  969. if sysUser == nil {
  970. br.Msg = "请登录"
  971. br.ErrMsg = "请登录,SysUser Is Empty"
  972. br.Ret = 408
  973. return
  974. }
  975. var req data_manage.CopyAddChartInfoReq
  976. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  977. if err != nil {
  978. br.Msg = "参数解析异常!"
  979. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  980. return
  981. }
  982. if req.ChartInfoId <= 0 {
  983. br.Msg = "参数有误"
  984. br.ErrMsg = fmt.Sprintf("参数有误, ChartInfoId: %d", req.ChartInfoId)
  985. return
  986. }
  987. req.ChartName = strings.TrimSpace(req.ChartName)
  988. if req.ChartName == "" {
  989. br.Msg = "请输入图表名称"
  990. return
  991. }
  992. if req.ChartClassifyId <= 0 {
  993. br.Msg = "请选择图表分类"
  994. return
  995. }
  996. deleteCache := true
  997. cacheKey := "CACHE_CHART_INFO_ADD_" + strconv.Itoa(sysUser.AdminId)
  998. defer func() {
  999. if deleteCache {
  1000. utils.Rc.Delete(cacheKey)
  1001. }
  1002. }()
  1003. if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) {
  1004. deleteCache = false
  1005. br.Msg = "系统处理中,请稍后重试!"
  1006. br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(this.Ctx.Input.RequestBody)
  1007. return
  1008. }
  1009. chartSource := utils.CHART_SOURCE_RANGE_ANALYSIS
  1010. // 校验分类、图表名称
  1011. {
  1012. var cond string
  1013. var pars []interface{}
  1014. switch this.Lang {
  1015. case utils.EnLangVersion:
  1016. cond += " AND chart_name_en = ? AND source = ? "
  1017. default:
  1018. cond += " AND chart_name = ? AND source = ? "
  1019. }
  1020. pars = append(pars, req.ChartName, chartSource)
  1021. count, e := data_manage.GetChartInfoCountByCondition(cond, pars)
  1022. if e != nil {
  1023. br.Msg = "保存失败"
  1024. br.ErrMsg = fmt.Sprintf("获取同名图表失败, Err: %v", e)
  1025. return
  1026. }
  1027. if count > 0 {
  1028. br.Msg = "图表名称已存在, 请重新填写"
  1029. return
  1030. }
  1031. _, e = data_manage.GetChartClassifyById(req.ChartClassifyId)
  1032. if e != nil {
  1033. if e.Error() == utils.ErrNoRow() {
  1034. br.Msg = "分类不存在"
  1035. return
  1036. }
  1037. br.Msg = "保存失败"
  1038. br.ErrMsg = fmt.Sprintf("获取图表分类失败, Err: %v", e)
  1039. return
  1040. }
  1041. }
  1042. // 图表信息
  1043. originChart, e := data_manage.GetChartInfoById(req.ChartInfoId)
  1044. if e != nil {
  1045. if e.Error() == utils.ErrNoRow() {
  1046. br.Msg = "原图表不存在"
  1047. return
  1048. }
  1049. br.Msg = "保存失败"
  1050. br.ErrMsg = fmt.Sprintf("获取原图表信息失败, Err: %v", e)
  1051. return
  1052. }
  1053. if originChart.Source == utils.CHART_SOURCE_ROLLING_CORRELATION {
  1054. br.Msg = `滚动区间计算图不支持另存为`
  1055. br.IsSendEmail = false
  1056. return
  1057. }
  1058. // 普通区间计算图表
  1059. chartInfo := new(data_manage.ChartInfo)
  1060. newChart, err, errMsg, isSendEmail := rangeServ.CopyChartInfo(req.ChartClassifyId, req.ChartName, originChart, sysUser, this.Lang)
  1061. chartInfo = newChart
  1062. if err != nil {
  1063. br.Msg = "保存失败"
  1064. if errMsg != `` {
  1065. br.Msg = errMsg
  1066. }
  1067. br.ErrMsg = err.Error()
  1068. br.IsSendEmail = isSendEmail
  1069. return
  1070. }
  1071. // 新增操作日志
  1072. {
  1073. chartLog := new(data_manage.ChartInfoLog)
  1074. chartLog.ChartInfoId = chartInfo.ChartInfoId
  1075. chartLog.ChartName = req.ChartName
  1076. chartLog.ChartClassifyId = req.ChartClassifyId
  1077. chartLog.SysUserId = sysUser.AdminId
  1078. chartLog.SysUserRealName = sysUser.RealName
  1079. chartLog.UniqueCode = chartInfo.UniqueCode
  1080. chartLog.CreateTime = time.Now()
  1081. chartLog.Content = string(this.Ctx.Input.RequestBody)
  1082. chartLog.Status = "复制区间计算图表"
  1083. chartLog.Method = this.Ctx.Input.URI()
  1084. go data_manage.AddChartInfoLog(chartLog)
  1085. }
  1086. br.Ret = 200
  1087. br.Success = true
  1088. br.Msg = "保存成功"
  1089. br.Data = data_manage.AddChartInfoResp{
  1090. ChartInfoId: chartInfo.ChartInfoId,
  1091. UniqueCode: chartInfo.UniqueCode,
  1092. ChartType: chartInfo.ChartType,
  1093. }
  1094. br.IsAddLog = true
  1095. }
  1096. // Refresh
  1097. // @Title 图表刷新接口
  1098. // @Description 图表刷新接口
  1099. // @Param ChartInfoId query int true "图表id"
  1100. // @Param UniqueCode query string true "唯一code"
  1101. // @Success Ret=200 刷新成功
  1102. // @router /chart_info/refresh [get]
  1103. func (this *RangeChartChartInfoController) Refresh() {
  1104. br := new(models.BaseResponse).Init()
  1105. defer func() {
  1106. this.Data["json"] = br
  1107. this.ServeJSON()
  1108. }()
  1109. sysUser := this.SysUser
  1110. if sysUser == nil {
  1111. br.Msg = "请登录"
  1112. br.ErrMsg = "请登录,SysUser Is Empty"
  1113. br.Ret = 408
  1114. return
  1115. }
  1116. chartInfoId, _ := this.GetInt("ChartInfoId")
  1117. uniqueCode := this.GetString("UniqueCode")
  1118. if chartInfoId <= 0 && uniqueCode == `` {
  1119. br.Msg = "参数错误"
  1120. br.ErrMsg = "参数错误:chartInfoId:" + strconv.Itoa(chartInfoId) + ",UniqueCode:" + uniqueCode
  1121. return
  1122. }
  1123. var chartInfo *data_manage.ChartInfo
  1124. var err error
  1125. if chartInfoId > 0 {
  1126. chartInfo, err = data_manage.GetChartInfoById(chartInfoId)
  1127. } else {
  1128. chartInfo, err = data_manage.GetChartInfoByUniqueCode(uniqueCode)
  1129. }
  1130. if err != nil {
  1131. if err.Error() == utils.ErrNoRow() {
  1132. br.Msg = "图表已被删除,无需刷新"
  1133. br.ErrMsg = "获取指标信息失败,Err:" + err.Error()
  1134. return
  1135. }
  1136. br.Msg = "刷新失败"
  1137. br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
  1138. return
  1139. }
  1140. // 刷新区间计算图表
  1141. isAsync, e := rangeServ.ChartInfoRefresh(chartInfo.ChartInfoId, chartInfo.UniqueCode)
  1142. if e != nil {
  1143. br.Msg = "刷新失败"
  1144. br.ErrMsg = "刷新区间计算图表失败, Err:" + err.Error()
  1145. return
  1146. }
  1147. // 多因子区间计算异步刷新, 前端提示
  1148. if isAsync {
  1149. br.Ret = 200
  1150. br.Success = true
  1151. br.Msg = "刷新时间较长, 请10分钟后查看"
  1152. return
  1153. }
  1154. //清除图表缓存
  1155. {
  1156. key := utils.HZ_CHART_LIB_DETAIL + chartInfo.UniqueCode
  1157. _ = utils.Rc.Delete(key)
  1158. }
  1159. br.Ret = 200
  1160. br.Success = true
  1161. br.Msg = "刷新成功"
  1162. }
  1163. // MultipleGraphConfigSaveEdb
  1164. // @Title 保存指标接口
  1165. // @Description 保存指标接口
  1166. // @Param request body request.SaveMultipleGraphEdbReq true "type json string"
  1167. // @Success Ret=200 返回指标id
  1168. // @router /edb/save [post]
  1169. func (this *RangeChartChartInfoController) MultipleGraphConfigSaveEdb() {
  1170. br := new(models.BaseResponse).Init()
  1171. defer func() {
  1172. this.Data["json"] = br
  1173. this.ServeJSON()
  1174. }()
  1175. sysUser := this.SysUser
  1176. if sysUser == nil {
  1177. br.Msg = "请登录"
  1178. br.ErrMsg = "请登录,SysUser Is Empty"
  1179. br.Ret = 408
  1180. return
  1181. }
  1182. var req data_manage.SaveChartRangeAnalysisEdbReq
  1183. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1184. if err != nil {
  1185. br.Msg = "参数解析异常!"
  1186. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1187. return
  1188. }
  1189. cacheKey := "CACHE_CHART_EDB_INFO_ADD_" + strconv.Itoa(sysUser.AdminId)
  1190. if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) {
  1191. br.Msg = "系统处理中,请稍后重试!"
  1192. br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(this.Ctx.Input.RequestBody)
  1193. return
  1194. }
  1195. defer func() {
  1196. _ = utils.Rc.Delete(cacheKey)
  1197. }()
  1198. fromEdbInfoIds := make([]int, 0)
  1199. for _, v := range req.EdbInfoList {
  1200. fromEdbInfoIds = append(fromEdbInfoIds, v.FromEdbInfoId)
  1201. }
  1202. fromEdbInfoMappingList, err := data_manage.GetChartEdbMappingListByEdbInfoIdList(fromEdbInfoIds)
  1203. if err != nil {
  1204. br.Msg = "获取失败"
  1205. br.ErrMsg = "获取图表,指标信息失败,Err:" + err.Error()
  1206. return
  1207. }
  1208. fromEdbInfoMap := make(map[int]*data_manage.ChartEdbInfoMapping, 0)
  1209. for _, v := range fromEdbInfoMappingList {
  1210. fromEdbInfoMap[v.EdbInfoId] = v
  1211. }
  1212. for _, v := range req.EdbInfoList {
  1213. if _, ok := fromEdbInfoMap[v.FromEdbInfoId]; !ok {
  1214. br.Msg = "指标信息不存在"
  1215. br.ErrMsg = "指标信息不存在,EdbInfoId:" + strconv.Itoa(v.FromEdbInfoId)
  1216. br.IsSendEmail = false
  1217. return
  1218. }
  1219. }
  1220. // 区间计算图表配置校验
  1221. extraConfig := req.ExtraConfig
  1222. // 区间计算图表配置校验
  1223. var config data_manage.ChartRangeAnalysisExtraConf
  1224. if req.ExtraConfig == `` {
  1225. br.Msg = "请输入配置信息"
  1226. return
  1227. }
  1228. err = json.Unmarshal([]byte(req.ExtraConfig), &config)
  1229. if err != nil {
  1230. br.Msg = "配置信息格式错误"
  1231. br.ErrMsg = "配置信息格式错误,Err:" + err.Error()
  1232. return
  1233. }
  1234. err, errMsg, isSendEmail := rangeServ.CheckChartRangeExtraConfig(config)
  1235. if err != nil {
  1236. br.Msg = "配置信息校验失败"
  1237. br.ErrMsg = errMsg
  1238. br.IsSendEmail = isSendEmail
  1239. return
  1240. }
  1241. multipleGraphConfigEdbMappingList, err := data_manage.GetMultipleGraphConfigEdbMappingListByIdAndSource(req.MultipleGraphConfigId, utils.CHART_SOURCE_RANGE_ANALYSIS)
  1242. if err != nil {
  1243. br.Msg = `保存失败`
  1244. br.ErrMsg = "查询配置与图表的关联关系失败,ERR:" + err.Error()
  1245. return
  1246. }
  1247. deleteEdbInfoIds := make([]int, 0) // 需要解除绑定的指标ID
  1248. fromEdbMap := make(map[int]int)
  1249. configMapping := make(map[int]*data_manage.MultipleGraphConfigEdbMapping, 0)
  1250. if len(multipleGraphConfigEdbMappingList) == 0 || req.IsSaveAs {
  1251. // 需要新增的指标
  1252. } else {
  1253. // 需要更新的指标
  1254. // 查询原先所有指标的来源指标,进一步筛选出需要新增,或者更新 或者删除的指标
  1255. oldEdbInfoIds := make([]int, 0)
  1256. for _, v := range multipleGraphConfigEdbMappingList {
  1257. configMapping[v.EdbInfoId] = v
  1258. oldEdbInfoIds = append(oldEdbInfoIds, v.EdbInfoId)
  1259. }
  1260. oldEdbCalculateMappingList, e := data_manage.GetEdbInfoCalculateMappingListByEdbInfoIds(oldEdbInfoIds)
  1261. if e != nil {
  1262. br.Msg = `保存失败`
  1263. br.ErrMsg = "获取计算指标信息失败,ERR:" + e.Error()
  1264. return
  1265. }
  1266. // 说明指标还在,没有被删除
  1267. for _, v := range oldEdbCalculateMappingList {
  1268. fromEdbMap[v.FromEdbInfoId] = v.EdbInfoId
  1269. if !utils.InArrayByInt(fromEdbInfoIds, v.FromEdbInfoId) && (config.EdbInfoMode == 1 || req.EdbInfoType != v.FromEdbInfoType) {
  1270. deleteEdbInfoIds = append(deleteEdbInfoIds, v.EdbInfoId)
  1271. }
  1272. }
  1273. }
  1274. resp := data_manage.BatchEdbInfoCalculateBatchSaveResp{
  1275. Fail: make([]data_manage.BatchEdbInfoCalculateBatchSaveFailResp, 0),
  1276. Success: make([]data_manage.BatchEdbInfoCalculateBatchSaveSuccessResp, 0),
  1277. }
  1278. // 普通指标批量新增\批量编辑
  1279. var saveReq data_manage.BatchEdbInfoCalculateBatchSaveReq
  1280. calculateEdbList := make([]data_manage.BatchEdbInfoCalculateBatchSaveSuccessResp, 0)
  1281. addReqEdbList := make([]*data_manage.CalculateEdbInfoItem, 0)
  1282. editReqEdbList := make([]*data_manage.CalculateEdbInfoItem, 0)
  1283. for _, v := range req.EdbInfoList {
  1284. v.CalculateId = strconv.Itoa(v.FromEdbInfoId)
  1285. v.EdbName = strings.Trim(v.EdbName, " ")
  1286. if v.EdbName == "" {
  1287. resp.Fail = append(resp.Fail, data_manage.BatchEdbInfoCalculateBatchSaveFailResp{
  1288. CalculateId: v.CalculateId,
  1289. Msg: "指标名称不能为空",
  1290. })
  1291. continue
  1292. }
  1293. if v.Frequency == "" {
  1294. resp.Fail = append(resp.Fail, data_manage.BatchEdbInfoCalculateBatchSaveFailResp{
  1295. CalculateId: v.CalculateId,
  1296. Msg: "频率不能为空",
  1297. })
  1298. continue
  1299. }
  1300. if v.Unit == "" {
  1301. resp.Fail = append(resp.Fail, data_manage.BatchEdbInfoCalculateBatchSaveFailResp{
  1302. CalculateId: v.CalculateId,
  1303. Msg: "单位不能为空",
  1304. })
  1305. continue
  1306. }
  1307. if v.ClassifyId <= 0 {
  1308. resp.Fail = append(resp.Fail, data_manage.BatchEdbInfoCalculateBatchSaveFailResp{
  1309. CalculateId: v.CalculateId,
  1310. Msg: "请选择分类",
  1311. })
  1312. continue
  1313. }
  1314. //加入缓存机制,避免创建同一个名称的指标 start
  1315. redisKey := fmt.Sprint("edb_info:calculate:batch:save:", utils.DATA_SOURCE_CALCULATE_RANGEANLYSIS, ":", v.EdbName)
  1316. //加入缓存机制,避免创建同一个名称的指标 start
  1317. if req.EdbInfoType == 1 {
  1318. redisKey = fmt.Sprint("predict_edb_info:calculate:batch:save:", sysUser.AdminId, ":", utils.DATA_SOURCE_CALCULATE_RANGEANLYSIS, ":", v.CalculateId)
  1319. }
  1320. isExist := utils.Rc.IsExist(redisKey)
  1321. if isExist {
  1322. resp.Fail = append(resp.Fail, data_manage.BatchEdbInfoCalculateBatchSaveFailResp{
  1323. CalculateId: strconv.Itoa(v.FromEdbInfoId),
  1324. Msg: "指标正在处理,请勿重复提交",
  1325. })
  1326. continue
  1327. } else {
  1328. }
  1329. if v.EdbInfoId > 0 {
  1330. editReqEdbList = append(editReqEdbList, v)
  1331. } else {
  1332. addReqEdbList = append(addReqEdbList, v)
  1333. }
  1334. }
  1335. if len(editReqEdbList) <= 0 && len(addReqEdbList) <= 0 {
  1336. br.Msg = "新增失败!"
  1337. if len(resp.Fail) > 0 {
  1338. br.ErrMsg = resp.Fail[0].Msg
  1339. } else {
  1340. br.Msg = "请选择指标"
  1341. }
  1342. return
  1343. }
  1344. if req.EdbInfoType == 0 { //普通指标
  1345. saveReq.Source = utils.DATA_SOURCE_CALCULATE_RANGEANLYSIS
  1346. saveReq.CalculateFormula = extraConfig
  1347. saveReq.AdminId = sysUser.AdminId
  1348. saveReq.AdminName = sysUser.RealName
  1349. if len(addReqEdbList) > 0 {
  1350. saveReq.EdbList = addReqEdbList
  1351. // 调用指标库去更新
  1352. reqJson, err := json.Marshal(saveReq)
  1353. if err != nil {
  1354. br.Msg = "参数解析异常!"
  1355. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1356. return
  1357. }
  1358. respItem, err := data.BatchSaveEdbCalculateMultiData(string(reqJson), this.Lang)
  1359. if err != nil {
  1360. br.Msg = "新增失败!"
  1361. br.ErrMsg = "新增失败,Err:" + err.Error()
  1362. return
  1363. }
  1364. if respItem.Ret != 200 {
  1365. br.Msg = respItem.Msg
  1366. br.ErrMsg = respItem.ErrMsg
  1367. return
  1368. }
  1369. resp = respItem.Data
  1370. calculateEdbList = respItem.Data.Success
  1371. }
  1372. if len(editReqEdbList) > 0 {
  1373. saveReq.EdbList = addReqEdbList
  1374. // 调用指标库去更新
  1375. reqJson, err := json.Marshal(saveReq)
  1376. if err != nil {
  1377. br.Msg = "参数解析异常!"
  1378. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1379. return
  1380. }
  1381. respItem, err := data.BatchEditEdbCalculateMultiData(string(reqJson), this.Lang)
  1382. if err != nil {
  1383. br.Msg = "更新失败!"
  1384. br.ErrMsg = "更新失败,Err:" + err.Error()
  1385. return
  1386. }
  1387. if respItem.Ret != 200 {
  1388. br.Msg = respItem.Msg
  1389. br.ErrMsg = respItem.ErrMsg
  1390. return
  1391. }
  1392. resp.Fail = append(resp.Fail, respItem.Data.Fail...)
  1393. calculateEdbList = append(calculateEdbList, respItem.Data.Success...)
  1394. }
  1395. } else if req.EdbInfoType == 1 {
  1396. // 预测指标
  1397. for _, v := range req.EdbInfoList {
  1398. predictReq := new(data_manage.PredictEdbInfoCalculateBatchSaveReq)
  1399. predictReq.EdbInfoId = v.EdbInfoId
  1400. predictReq.CalculateFormula = extraConfig
  1401. predictReq.EdbName = v.EdbName
  1402. predictReq.Frequency = v.Frequency
  1403. predictReq.Unit = v.Unit
  1404. predictReq.ClassifyId = v.ClassifyId
  1405. predictReq.FromEdbInfoId = v.FromEdbInfoId
  1406. predictReq.AdminId = sysUser.AdminId
  1407. predictReq.AdminName = sysUser.RealName
  1408. predictReq.Source = utils.DATA_SOURCE_PREDICT_CALCULATE_RANGEANLYSIS
  1409. reqJson, err := json.Marshal(predictReq)
  1410. if err != nil {
  1411. br.Msg = "参数解析异常!"
  1412. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1413. return
  1414. }
  1415. respItem, err := data.BatchSavePredictEdbData(string(reqJson), this.Lang)
  1416. if err != nil {
  1417. resp.Fail = append(resp.Fail, data_manage.BatchEdbInfoCalculateBatchSaveFailResp{
  1418. CalculateId: v.CalculateId,
  1419. Msg: "新增失败!",
  1420. ErrMsg: "新增失败,Err:" + err.Error(),
  1421. })
  1422. continue
  1423. }
  1424. if respItem.Ret != 200 {
  1425. resp.Fail = append(resp.Fail, data_manage.BatchEdbInfoCalculateBatchSaveFailResp{
  1426. CalculateId: v.CalculateId,
  1427. Msg: respItem.Msg,
  1428. ErrMsg: respItem.ErrMsg,
  1429. })
  1430. continue
  1431. }
  1432. calculateEdbList = append(calculateEdbList, data_manage.BatchEdbInfoCalculateBatchSaveSuccessResp{
  1433. CalculateId: v.CalculateId,
  1434. EdbInfoId: respItem.Data.EdbInfoId,
  1435. UniqueCode: respItem.Data.UniqueCode,
  1436. ClassifyId: predictReq.ClassifyId,
  1437. })
  1438. }
  1439. }
  1440. // 批量删除
  1441. if len(deleteEdbInfoIds) > 0 {
  1442. err = data_manage.DeleteMultipleGraphConfigEdbMappingByEdbIds(req.MultipleGraphConfigId, utils.CHART_SOURCE_RANGE_ANALYSIS, deleteEdbInfoIds)
  1443. if err != nil {
  1444. br.Msg = "更新失败!"
  1445. br.ErrMsg = "删除失败,Err:" + err.Error()
  1446. return
  1447. }
  1448. }
  1449. // 如果不是另存为的话,那么需要建立配置与指标的关系
  1450. if !req.IsSaveAs {
  1451. // 如果指标没有建立关联关系,那么就需要添加关系
  1452. configEdbMappingList := make([]*data_manage.MultipleGraphConfigEdbMapping, 0)
  1453. for _, v := range calculateEdbList {
  1454. item, ok := configMapping[v.EdbInfoId]
  1455. if !ok {
  1456. multipleGraphConfigEdbMapping := &data_manage.MultipleGraphConfigEdbMapping{
  1457. //Id: 0,
  1458. MultipleGraphConfigId: req.MultipleGraphConfigId,
  1459. EdbInfoId: v.EdbInfoId,
  1460. Source: utils.CHART_SOURCE_RANGE_ANALYSIS,
  1461. ModifyTime: time.Now(),
  1462. CreateTime: time.Now(),
  1463. }
  1464. configEdbMappingList = append(configEdbMappingList, multipleGraphConfigEdbMapping)
  1465. } else {
  1466. item.ModifyTime = time.Now()
  1467. err = item.Update([]string{"ModifyTime"})
  1468. if err != nil {
  1469. br.Msg = "保存失败"
  1470. br.ErrMsg = "保存配置与指标的关联关系失败,ERR:" + err.Error()
  1471. return
  1472. }
  1473. }
  1474. if len(configEdbMappingList) > 0 {
  1475. err = data_manage.AddMultipleGraphConfigEdbMappingList(configEdbMappingList)
  1476. if err != nil {
  1477. br.Msg = "保存失败"
  1478. br.ErrMsg = "保存配置与指标的关联关系失败,ERR:" + err.Error()
  1479. return
  1480. }
  1481. }
  1482. }
  1483. }
  1484. resp.Success = calculateEdbList
  1485. br.Ret = 200
  1486. br.Success = true
  1487. br.Msg = "保存成功"
  1488. br.Data = resp
  1489. br.IsAddLog = true
  1490. }
  1491. // MultipleGraphConfigEdbList
  1492. // @Title 获取指标列表接口
  1493. // @Description 获取指标列表接口
  1494. // @Param request body request.SaveMultipleGraphEdbReq true "type json string"
  1495. // @Success Ret=200 返回指标id
  1496. // @router /edb/list [get]
  1497. func (this *RangeChartChartInfoController) MultipleGraphConfigEdbList() {
  1498. br := new(models.BaseResponse).Init()
  1499. defer func() {
  1500. this.Data["json"] = br
  1501. this.ServeJSON()
  1502. }()
  1503. sysUser := this.SysUser
  1504. if sysUser == nil {
  1505. br.Msg = "请登录"
  1506. br.ErrMsg = "请登录,SysUser Is Empty"
  1507. br.Ret = 408
  1508. return
  1509. }
  1510. multipleGraphConfigId, _ := this.GetInt("MultipleGraphConfigId")
  1511. if multipleGraphConfigId <= 0 {
  1512. br.Msg = "参数错误"
  1513. br.ErrMsg = "参数错误,MultipleGraphConfigId Is Empty"
  1514. return
  1515. }
  1516. list := make([]*data_manage.ChartRangeAnalysisConfigEdbItem, 0)
  1517. resp := data_manage.ChartRangeAnalysisConfigEdbResp{EdbInfoList: list}
  1518. multipleGraphConfigEdbMappingList, err := data_manage.GetMultipleGraphConfigEdbMappingListByIdAndSource(multipleGraphConfigId, utils.CHART_SOURCE_RANGE_ANALYSIS)
  1519. if err != nil {
  1520. br.Msg = `保存失败`
  1521. br.ErrMsg = "查询配置与图表的关联关系失败,ERR:" + err.Error()
  1522. return
  1523. }
  1524. if len(multipleGraphConfigEdbMappingList) == 0 {
  1525. br.Ret = 200
  1526. br.Success = true
  1527. br.Msg = "操作成功"
  1528. br.Data = resp
  1529. br.IsAddLog = true
  1530. return
  1531. }
  1532. edbInfoIds := make([]int, 0)
  1533. for _, v := range multipleGraphConfigEdbMappingList {
  1534. edbInfoIds = append(edbInfoIds, v.EdbInfoId)
  1535. }
  1536. edbList, err := data_manage.GetChartEdbMappingListByEdbInfoIdList(edbInfoIds)
  1537. if err != nil {
  1538. br.Msg = "获取失败"
  1539. br.ErrMsg = "获取图表,指标信息失败,Err:" + err.Error()
  1540. return
  1541. }
  1542. edbInfoMap := make(map[int]*data_manage.ChartEdbInfoMapping, 0)
  1543. for _, v := range edbList {
  1544. edbInfoMap[v.EdbInfoId] = v
  1545. }
  1546. edbCalculateMappingList, e := data_manage.GetEdbInfoCalculateMappingListByEdbInfoIds(edbInfoIds)
  1547. if e != nil {
  1548. br.Msg = `保存失败`
  1549. br.ErrMsg = "获取计算指标信息失败,ERR:" + e.Error()
  1550. return
  1551. }
  1552. // 说明指标还在,没有被删除
  1553. for _, v := range edbCalculateMappingList {
  1554. tmp := new(data_manage.ChartRangeAnalysisConfigEdbItem)
  1555. info, ok := edbInfoMap[v.EdbInfoId]
  1556. if ok {
  1557. tmp.EdbInfoId = v.EdbInfoId
  1558. tmp.Unit = info.Unit
  1559. tmp.UnitEn = info.UnitEn
  1560. tmp.Frequency = info.Frequency
  1561. tmp.EdbNameEn = info.EdbNameEn
  1562. tmp.EdbName = info.EdbName
  1563. tmp.ClassifyId = info.ClassifyId
  1564. tmp.FromEdbInfoId = v.FromEdbInfoId
  1565. tmp.EdbTypeInfo = info.EdbInfoCategoryType
  1566. list = append(list, tmp)
  1567. }
  1568. }
  1569. resp.EdbInfoList = list
  1570. br.Ret = 200
  1571. br.Success = true
  1572. br.Msg = "保存成功"
  1573. br.Data = resp
  1574. br.IsAddLog = true
  1575. }
  1576. // SearchByEs
  1577. // @Title 图表模糊搜索(从es获取)
  1578. // @Description 图表模糊搜索(从es获取)
  1579. // @Param Keyword query string true "图表名称"
  1580. // @Param IsShowMe query bool true "是否只看我的,true、false"
  1581. // @Param Source query int true "来源,3:相关性,4:滚动相关性,默认0:全部"
  1582. // @Success 200 {object} data_manage.ChartInfo
  1583. // @router /chart_info/search_by_es [get]
  1584. func (this *RangeChartChartInfoController) SearchByEs() {
  1585. br := new(models.BaseResponse).Init()
  1586. defer func() {
  1587. this.Data["json"] = br
  1588. this.ServeJSON()
  1589. }()
  1590. sysUser := this.SysUser
  1591. if sysUser == nil {
  1592. br.Msg = "请登录"
  1593. br.ErrMsg = "请登录,SysUser Is Empty"
  1594. br.Ret = 408
  1595. return
  1596. }
  1597. pageSize, _ := this.GetInt("PageSize")
  1598. currentIndex, _ := this.GetInt("CurrentIndex")
  1599. var startSize int
  1600. if pageSize <= 0 {
  1601. pageSize = utils.PageSize20
  1602. }
  1603. if currentIndex <= 0 {
  1604. currentIndex = 1
  1605. }
  1606. startSize = paging.StartIndex(currentIndex, pageSize)
  1607. keyword := this.GetString("Keyword")
  1608. //只看我的
  1609. isShowMe, _ := this.GetBool("IsShowMe")
  1610. showSysId := 0
  1611. if isShowMe {
  1612. showSysId = sysUser.AdminId
  1613. }
  1614. sourceList := make([]int, 0)
  1615. sourceList = append(sourceList, utils.CHART_SOURCE_RANGE_ANALYSIS)
  1616. var searchList []*data_manage.ChartInfo
  1617. var total int64
  1618. var err error
  1619. // 获取当前账号的不可见指标
  1620. noPermissionChartIdList := make([]int, 0)
  1621. {
  1622. obj := data_manage.EdbInfoNoPermissionAdmin{}
  1623. confList, err := obj.GetAllChartListByAdminId(this.SysUser.AdminId)
  1624. if err != nil && err.Error() != utils.ErrNoRow() {
  1625. br.Msg = "获取失败"
  1626. br.ErrMsg = "获取不可见指标配置数据失败,Err:" + err.Error()
  1627. return
  1628. }
  1629. for _, v := range confList {
  1630. noPermissionChartIdList = append(noPermissionChartIdList, v.ChartInfoId)
  1631. }
  1632. }
  1633. if keyword != "" {
  1634. searchList, total, err = data.EsSearchChartInfo(keyword, showSysId, sourceList, noPermissionChartIdList, startSize, pageSize)
  1635. } else {
  1636. total, searchList, err = data_manage.ChartInfoSearchByEmptyKeyWord(showSysId, sourceList, noPermissionChartIdList, startSize, pageSize)
  1637. if err != nil && err.Error() != utils.ErrNoRow() {
  1638. br.Msg = "获取失败"
  1639. br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
  1640. return
  1641. }
  1642. }
  1643. finalList := make([]*data_manage.ChartInfoMore, 0)
  1644. if len(searchList) > 0 {
  1645. chartInfoIds := ""
  1646. chartEdbMap := make(map[int][]*data_manage.ChartEdbInfoMapping)
  1647. for _, v := range searchList {
  1648. chartInfoIds += strconv.Itoa(v.ChartInfoId) + ","
  1649. }
  1650. if chartInfoIds != "" {
  1651. chartInfoIds = strings.Trim(chartInfoIds, ",")
  1652. //判断是否需要展示英文标识
  1653. edbList, e := data_manage.GetChartEdbMappingListByChartInfoIds(chartInfoIds)
  1654. if e != nil {
  1655. br.Msg = "获取失败"
  1656. br.ErrMsg = "获取图表,指标信息失败,Err:" + e.Error()
  1657. return
  1658. }
  1659. for _, v := range edbList {
  1660. chartEdbMap[v.ChartInfoId] = append(chartEdbMap[v.ChartInfoId], v)
  1661. }
  1662. }
  1663. for _, v := range searchList {
  1664. tmp := new(data_manage.ChartInfoMore)
  1665. tmp.ChartInfo = *v
  1666. // 图表数据权限
  1667. tmp.HaveOperaAuth = true
  1668. //判断是否需要展示英文标识
  1669. if edbTmpList, ok := chartEdbMap[v.ChartInfoId]; ok {
  1670. tmp.IsEnChart = data.CheckIsEnChart(v.ChartNameEn, edbTmpList, v.Source, v.ChartType)
  1671. }
  1672. finalList = append(finalList, tmp)
  1673. }
  1674. }
  1675. //新增搜索词记录
  1676. {
  1677. searchKeyword := new(data_manage.SearchKeyword)
  1678. searchKeyword.KeyWord = keyword
  1679. searchKeyword.CreateTime = time.Now()
  1680. go data_manage.AddSearchKeyword(searchKeyword)
  1681. }
  1682. page := paging.GetPaging(currentIndex, pageSize, int(total))
  1683. resp := data_manage.ChartInfoListByEsResp{
  1684. Paging: page,
  1685. List: finalList,
  1686. }
  1687. br.Ret = 200
  1688. br.Success = true
  1689. br.Msg = "获取成功"
  1690. br.Data = resp
  1691. }
  1692. // BaseInfoEdit
  1693. // @Title 编辑图表基础信息接口
  1694. // @Description 编辑图表基础信息接口
  1695. // @Param request body data_manage.EditChartInfoBaseReq true "type json string"
  1696. // @Success Ret=200 编辑成功
  1697. // @router /chart_info/base/edit [post]
  1698. func (this *RangeChartChartInfoController) BaseInfoEdit() {
  1699. br := new(models.BaseResponse).Init()
  1700. defer func() {
  1701. this.Data["json"] = br
  1702. this.ServeJSON()
  1703. }()
  1704. sysUser := this.SysUser
  1705. if sysUser == nil {
  1706. br.Msg = "请登录"
  1707. br.ErrMsg = "请登录,SysUser Is Empty"
  1708. br.Ret = 408
  1709. return
  1710. }
  1711. var req data_manage.EditChartRangeBaseReq
  1712. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1713. if err != nil {
  1714. br.Msg = "参数解析异常!"
  1715. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1716. return
  1717. }
  1718. req.ChartName = strings.Trim(req.ChartName, " ")
  1719. if req.ChartInfoId <= 0 {
  1720. br.Msg = "请选择图表"
  1721. return
  1722. }
  1723. if req.ChartName == "" {
  1724. br.Msg = "请输入图表名称"
  1725. return
  1726. }
  1727. chartItem, e := data_manage.GetChartInfoById(req.ChartInfoId)
  1728. if e != nil {
  1729. if e.Error() == utils.ErrNoRow() {
  1730. br.Msg = "图表已被删除, 请刷新页面"
  1731. return
  1732. }
  1733. br.Msg = "获取图表信息失败"
  1734. br.ErrMsg = "获取图表信息失败, Err: " + e.Error()
  1735. return
  1736. }
  1737. if chartItem.Source != utils.CHART_SOURCE_RANGE_ANALYSIS {
  1738. br.Msg = "该图不是区间计算图表"
  1739. return
  1740. }
  1741. var condition string
  1742. var pars []interface{}
  1743. condition += " AND chart_info_id <> ? AND source = ? "
  1744. pars = append(pars, req.ChartInfoId, utils.CHART_SOURCE_RANGE_ANALYSIS)
  1745. switch this.Lang {
  1746. case utils.EnLangVersion:
  1747. condition += " AND chart_name_en = ? "
  1748. default:
  1749. condition += " AND chart_name = ? "
  1750. }
  1751. pars = append(pars, req.ChartName)
  1752. existItem, err := data_manage.GetChartInfoByCondition(condition, pars)
  1753. if err != nil {
  1754. if err.Error() != utils.ErrNoRow() {
  1755. br.Msg = "判断英文图表名称是否存在失败"
  1756. br.ErrMsg = "判断英文图表名称是否存在失败,Err:" + err.Error()
  1757. return
  1758. }
  1759. }
  1760. if err == nil && existItem.ChartInfoId > 0 {
  1761. br.Msg = existItem.ChartName + ":" + req.ChartName + "图表名称已存在"
  1762. return
  1763. }
  1764. switch this.Lang {
  1765. case utils.EnLangVersion:
  1766. chartItem.ChartNameEn = req.ChartName
  1767. default:
  1768. chartItem.ChartName = req.ChartName
  1769. }
  1770. chartItem.ModifyTime = time.Now().Local()
  1771. if e := chartItem.Update([]string{"ChartName", "ChartNameEn", "ModifyTime"}); e != nil {
  1772. br.Msg = "操作失败"
  1773. br.ErrMsg = "更新图表信息失败, Err: " + e.Error()
  1774. return
  1775. }
  1776. //添加es数据
  1777. go data.EsAddOrEditChartInfo(chartItem.ChartInfoId)
  1778. //修改my eta es数据
  1779. go data.EsAddOrEditMyChartInfoByChartInfoId(chartItem.ChartInfoId)
  1780. //新增操作日志
  1781. {
  1782. chartLog := new(data_manage.ChartInfoLog)
  1783. chartLog.ChartName = chartItem.ChartName
  1784. chartLog.ChartInfoId = req.ChartInfoId
  1785. chartLog.ChartClassifyId = chartItem.ChartClassifyId
  1786. chartLog.SysUserId = sysUser.AdminId
  1787. chartLog.SysUserRealName = sysUser.RealName
  1788. chartLog.UniqueCode = chartItem.UniqueCode
  1789. chartLog.CreateTime = time.Now()
  1790. chartLog.Content = string(this.Ctx.Input.RequestBody)
  1791. chartLog.Status = "编辑区间计算图表基础信息"
  1792. chartLog.Method = this.Ctx.Input.URL()
  1793. go data_manage.AddChartInfoLog(chartLog)
  1794. }
  1795. // 清除缓存
  1796. if utils.Re == nil && utils.Rc != nil {
  1797. _ = utils.Rc.Delete(utils.HZ_CHART_LIB_DETAIL + chartItem.UniqueCode) //图表分享链接缓存
  1798. _ = utils.Rc.Delete(data.GetChartInfoDataKey(req.ChartInfoId))
  1799. }
  1800. br.Ret = 200
  1801. br.Success = true
  1802. br.Msg = "编辑成功"
  1803. br.IsAddLog = true
  1804. }
  1805. // @Title 保存图表接口
  1806. // @Description 保存图表接口
  1807. // @Param request body data_manage.SaveChartInfoReq true "type json string"
  1808. // @Success Ret=200 返回图表id
  1809. // @router /chart_info/save [post]
  1810. func (this *RangeChartChartInfoController) ChartInfoSave() {
  1811. br := new(models.BaseResponse).Init()
  1812. defer func() {
  1813. this.Data["json"] = br
  1814. this.ServeJSON()
  1815. }()
  1816. sysUser := this.SysUser
  1817. if sysUser == nil {
  1818. br.Msg = "请登录"
  1819. br.ErrMsg = "请登录,SysUser Is Empty"
  1820. br.Ret = 408
  1821. return
  1822. }
  1823. var req data_manage.SaveChartRangeReq
  1824. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1825. if err != nil {
  1826. br.Msg = "参数解析异常!"
  1827. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1828. return
  1829. }
  1830. if req.ChartInfoId <= 0 {
  1831. br.Msg = "参数错误!"
  1832. return
  1833. }
  1834. chartItem, err := data_manage.GetChartInfoById(req.ChartInfoId)
  1835. if err != nil {
  1836. if err.Error() == utils.ErrNoRow() {
  1837. br.Msg = "图表已被删除,请刷新页面!"
  1838. br.ErrMsg = "图表已被删除,请刷新页面,ChartInfoId:" + strconv.Itoa(req.ChartInfoId)
  1839. return
  1840. }
  1841. br.Msg = "获取图表信息失败!"
  1842. br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
  1843. return
  1844. }
  1845. //图表操作权限
  1846. //ok := data.CheckOpChartPermission(sysUser, chartItem.SysUserId)
  1847. //if !ok {
  1848. // br.Msg = "没有该图表的操作权限"
  1849. // br.ErrMsg = "没有该图表的操作权限"
  1850. // return
  1851. //}
  1852. err = data_manage.EditRangeChartInfo(&req)
  1853. if err != nil {
  1854. br.Msg = "保存失败"
  1855. br.ErrMsg = "保存失败,Err:" + err.Error()
  1856. return
  1857. }
  1858. key := utils.HZ_CHART_LIB_DETAIL + chartItem.UniqueCode
  1859. if utils.Re == nil && utils.Rc != nil {
  1860. utils.Rc.Delete(key)
  1861. }
  1862. //修改es数据
  1863. go data.EsAddOrEditChartInfo(chartItem.ChartInfoId)
  1864. //修改my eta es数据
  1865. go data.EsAddOrEditMyChartInfoByChartInfoId(chartItem.ChartInfoId)
  1866. //新增操作日志
  1867. {
  1868. chartLog := new(data_manage.ChartInfoLog)
  1869. chartLog.ChartName = chartItem.ChartName
  1870. chartLog.ChartInfoId = req.ChartInfoId
  1871. chartLog.ChartClassifyId = chartItem.ChartClassifyId
  1872. chartLog.SysUserId = sysUser.AdminId
  1873. chartLog.SysUserRealName = sysUser.RealName
  1874. chartLog.UniqueCode = chartItem.UniqueCode
  1875. chartLog.CreateTime = time.Now()
  1876. chartLog.Content = string(this.Ctx.Input.RequestBody)
  1877. chartLog.Status = "修改配置项"
  1878. chartLog.Method = this.Ctx.Input.URI()
  1879. go data_manage.AddChartInfoLog(chartLog)
  1880. }
  1881. br.Ret = 200
  1882. br.Success = true
  1883. br.Msg = "保存成功"
  1884. br.IsAddLog = true
  1885. }