chart_info.go 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636
  1. package chart
  2. import (
  3. "context"
  4. "encoding/json"
  5. "fmt"
  6. "github.com/gin-gonic/gin"
  7. "hongze/hongze_yb/controller/response"
  8. "hongze/hongze_yb/global"
  9. "hongze/hongze_yb/models/request"
  10. responseModel "hongze/hongze_yb/models/response"
  11. "hongze/hongze_yb/models/response/chart_info"
  12. chartEdbMappingModel "hongze/hongze_yb/models/tables/chart_edb_mapping"
  13. chartInfoModel "hongze/hongze_yb/models/tables/chart_info"
  14. "hongze/hongze_yb/models/tables/chart_info_log"
  15. edbInfoModel "hongze/hongze_yb/models/tables/edb_info"
  16. "hongze/hongze_yb/models/tables/yb_my_chart"
  17. "hongze/hongze_yb/services/alarm_msg"
  18. "hongze/hongze_yb/services/chart"
  19. "hongze/hongze_yb/services/chart/cross_variety"
  20. "hongze/hongze_yb/services/user"
  21. "hongze/hongze_yb/utils"
  22. "sort"
  23. "strconv"
  24. "strings"
  25. "time"
  26. )
  27. // GetChartInfoDetail 获取图表详情
  28. // @Tags 图库模块
  29. // @Summary 获取图表详情
  30. // @Description 获取图表详情
  31. // @Security ApiKeyAuth
  32. // @Param Authorization header string true "Bearer 31a165baebe6dec616b1f8f3207b4273"
  33. // @Accept json
  34. // @Product json
  35. // @Param DateType query string false "时间段:1-00年至今; 2-10年至今; 3-15年至今; 4-21年至今; 5-指定区间; 6-指定年月至今; 7-18年至今; 8-19年至今; 9-20年至今"
  36. // @Param ClassifyId query string false "图表分类ID"
  37. // @Success 200 {object} chart_info.ChartInfoDetailResp
  38. // @failure 400 {string} string "图表详情获取失败"
  39. // @Router /my_chart/getChartInfoDetail [get]
  40. func GetChartInfoDetail(c *gin.Context) {
  41. // 图表ID
  42. reqChartInfoId := c.DefaultQuery("ChartInfoId", "")
  43. if reqChartInfoId == "" {
  44. response.Fail("参数有误:图表ID", c)
  45. return
  46. }
  47. chartInfoId, _ := strconv.Atoi(reqChartInfoId)
  48. reqStartDate := c.DefaultQuery("StartDate", "")
  49. reqEndDate := c.DefaultQuery("EndDate", "")
  50. // 图表样式类型
  51. reqChartType := c.DefaultQuery("ChartType", "")
  52. chartType, _ := strconv.Atoi(reqChartType)
  53. /*// 季节性图表时间
  54. reqSeasonStartDate := c.DefaultQuery("SeasonStartDate", "")
  55. reqSeasonEndDate := c.DefaultQuery("SeasonEndDate", "")*/
  56. // 指标ID
  57. edbInfoId := c.DefaultQuery("EdbInfoId", "")
  58. // 公历/农历
  59. reqCalendar := c.DefaultQuery("Calendar", "")
  60. // 获取图表信息
  61. var err error
  62. chartInfo := new(chartInfoModel.ChartInfoView)
  63. chartInfo, err = chartInfoModel.GetChartInfoViewById(chartInfoId)
  64. if err != nil {
  65. if err == utils.ErrNoRow {
  66. response.Custom(4003, "图表不存在,请刷新页面", c)
  67. return
  68. }
  69. response.FailMsg("获取失败", "获取图表信息失败, Err:"+err.Error(), c)
  70. return
  71. }
  72. // 获取主题样式
  73. chartTheme, err := chart.GetChartThemeConfig(chartInfo.ChartThemeId, chartInfo.Source, chartInfo.ChartType)
  74. if err != nil {
  75. response.FailMsg("获取失败", "获取主题信息失败, Err:"+err.Error(), c)
  76. return
  77. }
  78. chartInfo.ChartThemeStyle = chartTheme.Config
  79. chartInfo.ChartThemeId = chartTheme.ChartThemeID
  80. chartType = chartInfo.ChartType
  81. startDate := chartInfo.StartDate
  82. endDate := chartInfo.EndDate
  83. startYear := chartInfo.StartYear
  84. calendar := chartInfo.Calendar
  85. if reqCalendar != "" {
  86. calendar = reqCalendar
  87. }
  88. // 时段筛选
  89. reqDateType := c.DefaultQuery("DateType", "")
  90. dateType := chartInfo.DateType
  91. if reqDateType != "" {
  92. dateType, _ = strconv.Atoi(reqDateType)
  93. }
  94. if dateType <= 0 {
  95. dateType = 3 // 默认同后台15年至今
  96. }
  97. if reqStartDate != "" {
  98. startDate = reqStartDate
  99. }
  100. if reqEndDate != "" {
  101. endDate = reqEndDate
  102. }
  103. // 获取图表指标映射
  104. mappingList := make([]*chartEdbMappingModel.ChartEdbInfoMapping, 0)
  105. if chartInfoId > 0 {
  106. mappingList, err = chartEdbMappingModel.GetMappingListByChartInfoId(chartInfoId)
  107. if err != nil {
  108. response.FailMsg("获取失败", "获取图表指标信息失败4001, Err:"+err.Error(), c)
  109. return
  110. }
  111. } else {
  112. if edbInfoId != "" {
  113. mappingList, err = chartEdbMappingModel.GetMappingListByEdbInfoId(edbInfoId)
  114. if err != nil {
  115. response.FailMsg("获取失败", "获取图表指标信息失败4002, Err:"+err.Error(), c)
  116. return
  117. }
  118. }
  119. }
  120. yearMax := 0
  121. if dateType == utils.DateTypeNYears {
  122. for _, v := range mappingList {
  123. if v.LatestDate.Year() > yearMax {
  124. yearMax = v.LatestDate.Year()
  125. }
  126. }
  127. }
  128. startDate, endDate = utils.GetDateByDateTypeV2(dateType, startDate, endDate, startYear, yearMax)
  129. // 图表额外数据参数
  130. extraConfigStr := chartInfo.ExtraConfig
  131. // 柱方图的一些配置
  132. var barConfig request.BarChartInfoReq
  133. if chartInfo != nil && chartInfo.ChartType == 7 {
  134. if chartInfo.BarConfig == `` {
  135. response.FailMsg("柱方图未配置", "柱方图未配置", c)
  136. return
  137. }
  138. err = json.Unmarshal([]byte(chartInfo.BarConfig), &barConfig)
  139. if err != nil {
  140. response.FailMsg("柱方图配置异常", "柱方图配置异常", c)
  141. return
  142. }
  143. extraConfigStr = chartInfo.BarConfig
  144. }
  145. // 获取图表中的指标数据
  146. edbList, xEdbIdValue, yDataList, sourceArr, dataResp, err, errMsg := chart.GetChartEdbData(chartInfoId, chartType, calendar, startDate, endDate, mappingList, extraConfigStr, chartInfo.SeasonExtraConfig)
  147. if err != nil {
  148. msg := `获取失败`
  149. if errMsg != `` {
  150. msg = errMsg
  151. }
  152. response.FailMsg(msg, "获取图表,指标信息失败, Err:"+err.Error(), c)
  153. return
  154. }
  155. for _, v := range edbList {
  156. // 指标别名
  157. if barConfig.EdbInfoIdList != nil && len(barConfig.EdbInfoIdList) > 0 {
  158. for _, reqEdb := range barConfig.EdbInfoIdList {
  159. if v.EdbInfoId == reqEdb.EdbInfoId {
  160. v.EdbAliasName = reqEdb.Name
  161. }
  162. }
  163. }
  164. }
  165. sourceArr = append(sourceArr, "弘则研究")
  166. chartInfo.ChartSource = strings.Join(sourceArr, ",")
  167. // 访问记录-仅普通用户记录
  168. userInfo := user.GetInfoByClaims(c)
  169. ok, _, _ := user.GetAdminByUserInfo(userInfo)
  170. if !ok {
  171. reqMyChartClassifyId := c.DefaultQuery("MyChartClassifyId", "")
  172. myChartClassifyId, _ := strconv.Atoi(reqMyChartClassifyId)
  173. go chart.SaveChartVisitLog(userInfo, chartInfo, myChartClassifyId)
  174. }
  175. // 用户是否有收藏该图表
  176. ob := new(yb_my_chart.YbMyChart)
  177. cond := `user_id = ? AND chart_info_id = ?`
  178. pars := make([]interface{}, 0)
  179. pars = append(pars, userInfo.UserID, chartInfo.ChartInfoId)
  180. exists, e := ob.FetchByCondition(cond, pars)
  181. if e != nil && e != utils.ErrNoRow {
  182. response.FailMsg("操作失败", "获取用户图表失败, Err: "+e.Error(), c)
  183. return
  184. }
  185. myChartInfo := new(responseModel.MyChartItem)
  186. if exists != nil && exists.MyChartID > 0 {
  187. myChartInfo.MyChartID = exists.MyChartID
  188. myChartInfo.MyChartClassifyID = exists.MyChartClassifyID
  189. myChartInfo.ChartInfoID = exists.ChartInfoID
  190. myChartInfo.ChartName = exists.ChartName
  191. myChartInfo.UniqueCode = exists.UniqueCode
  192. myChartInfo.ChartImage = exists.ChartImage
  193. myChartInfo.UserID = exists.UserID
  194. myChartInfo.ReportID = exists.ReportID
  195. myChartInfo.ReportChapterID = exists.ReportChapterID
  196. myChartInfo.CreateTime = utils.TimeTransferString(utils.FormatDateTime, exists.CreateTime)
  197. }
  198. // 图表的指标来源
  199. sourceNameList, sourceNameEnList := chart.GetEdbSourceByEdbInfoIdList(edbList)
  200. chartInfo.ChartSource = strings.Join(sourceNameList, ",")
  201. chartInfo.ChartSourceEn = strings.Join(sourceNameEnList, ",")
  202. resp := new(chart_info.ChartInfoDetailResp)
  203. resp.ChartInfo = chartInfo
  204. resp.EdbInfoList = edbList
  205. resp.XEdbIdValue = xEdbIdValue
  206. resp.YDataList = yDataList
  207. resp.MyChartInfo = myChartInfo
  208. resp.DataResp = dataResp
  209. response.OkData("获取成功", resp, c)
  210. }
  211. func getChartInfoDetail(chartInfo *chartInfoModel.ChartInfoView, myChartClassifyId int, userInfo user.UserInfo) (resp *chart_info.ChartInfoDetailResp, isOk bool, msg, errMsg string) {
  212. // 获取图表信息
  213. var err error
  214. chartType := chartInfo.ChartType
  215. calendar := chartInfo.Calendar
  216. startDate := chartInfo.StartDate
  217. endDate := chartInfo.EndDate
  218. startYear := chartInfo.StartYear
  219. // 时段筛选
  220. dateType := chartInfo.DateType
  221. if dateType <= 0 {
  222. dateType = 3 // 默认同后台15年至今
  223. }
  224. // 获取图表指标映射
  225. mappingList := make([]*chartEdbMappingModel.ChartEdbInfoMapping, 0)
  226. mappingList, err = chartEdbMappingModel.GetMappingListByChartInfoId(chartInfo.ChartInfoId)
  227. if err != nil {
  228. msg = `获取失败`
  229. errMsg = "获取图表指标信息失败4001, Err:" + err.Error()
  230. return
  231. }
  232. yearMax := 0
  233. if dateType == utils.DateTypeNYears {
  234. for _, v := range mappingList {
  235. if v.LatestDate.Year() > yearMax {
  236. yearMax = v.LatestDate.Year()
  237. }
  238. }
  239. }
  240. startDate, endDate = utils.GetDateByDateTypeV2(dateType, startDate, endDate, startYear, yearMax)
  241. //fmt.Println("start_date:", startDate)
  242. //fmt.Println("end_date:", endDate)
  243. // 图表额外数据参数
  244. extraConfigStr := chartInfo.ExtraConfig
  245. // 柱方图的一些配置
  246. var barConfig request.BarChartInfoReq
  247. if chartInfo != nil && chartInfo.ChartType == 7 {
  248. if chartInfo.BarConfig == `` {
  249. msg = "柱方图未配置"
  250. errMsg = "柱方图未配置"
  251. return
  252. }
  253. err := json.Unmarshal([]byte(chartInfo.BarConfig), &barConfig)
  254. if err != nil {
  255. msg = "柱方图配置异常"
  256. errMsg = "柱方图配置异常"
  257. return
  258. }
  259. extraConfigStr = chartInfo.BarConfig
  260. }
  261. // 获取图表中的指标数据
  262. edbList, xEdbIdValue, yDataList, sourceArr, dataResp, err, tmpErrMsg := chart.GetChartEdbData(chartInfo.ChartInfoId, chartType, calendar, startDate, endDate, mappingList, extraConfigStr, chartInfo.SeasonExtraConfig)
  263. if err != nil {
  264. msg = `获取失败`
  265. if tmpErrMsg != `` {
  266. msg = tmpErrMsg
  267. }
  268. errMsg = "获取图表,指标信息失败, Err:" + err.Error()
  269. return
  270. }
  271. for _, v := range edbList {
  272. // 指标别名
  273. if barConfig.EdbInfoIdList != nil && len(barConfig.EdbInfoIdList) > 0 {
  274. for _, reqEdb := range barConfig.EdbInfoIdList {
  275. if v.EdbInfoId == reqEdb.EdbInfoId {
  276. v.EdbAliasName = reqEdb.Name
  277. }
  278. }
  279. }
  280. }
  281. sourceArr = append(sourceArr, "弘则研究")
  282. chartInfo.ChartSource = strings.Join(sourceArr, ",")
  283. // 访问记录-仅普通用户记录
  284. ok, _, _ := user.GetAdminByUserInfo(userInfo)
  285. if !ok {
  286. go chart.SaveChartVisitLog(userInfo, chartInfo, myChartClassifyId)
  287. }
  288. // 用户是否有收藏该图表
  289. ob := new(yb_my_chart.YbMyChart)
  290. cond := `user_id = ? AND chart_info_id = ?`
  291. pars := make([]interface{}, 0)
  292. pars = append(pars, userInfo.UserID, chartInfo.ChartInfoId)
  293. exists, e := ob.FetchByCondition(cond, pars)
  294. if e != nil && e != utils.ErrNoRow {
  295. msg = `操作失败`
  296. errMsg = "获取用户图表失败, Err: " + e.Error()
  297. return
  298. }
  299. myChartInfo := new(responseModel.MyChartItem)
  300. if exists != nil && exists.MyChartID > 0 {
  301. myChartInfo.MyChartID = exists.MyChartID
  302. myChartInfo.MyChartClassifyID = exists.MyChartClassifyID
  303. myChartInfo.ChartInfoID = exists.ChartInfoID
  304. myChartInfo.ChartName = exists.ChartName
  305. myChartInfo.UniqueCode = exists.UniqueCode
  306. myChartInfo.ChartImage = exists.ChartImage
  307. myChartInfo.UserID = exists.UserID
  308. myChartInfo.ReportID = exists.ReportID
  309. myChartInfo.ReportChapterID = exists.ReportChapterID
  310. myChartInfo.CreateTime = utils.TimeTransferString(utils.FormatDateTime, exists.CreateTime)
  311. }
  312. resp = new(chart_info.ChartInfoDetailResp)
  313. resp.ChartInfo = chartInfo
  314. resp.EdbInfoList = edbList
  315. resp.XEdbIdValue = xEdbIdValue
  316. resp.YDataList = yDataList
  317. resp.MyChartInfo = myChartInfo
  318. resp.DataResp = dataResp
  319. isOk = true
  320. return
  321. }
  322. // RefreshChartInfo 刷新图表信息
  323. // @Tags 图库模块
  324. // @Summary 刷新图表信息
  325. // @Description 刷新图表信息
  326. // @Security ApiKeyAuth
  327. // @Param Authorization header string true "Bearer 31a165baebe6dec616b1f8f3207b4273"
  328. // @Accept json
  329. // @Product json
  330. // @Param data body chartInfoModel.SaveChartInfoReq true "请求参数"
  331. // @Success 200 {string} string "操作成功"
  332. // @failure 400 {string} string "操作失败"
  333. // @Router /my_chart/refreshChartInfo [post]
  334. func RefreshChartInfo(c *gin.Context) {
  335. // 参数校验
  336. var req chartInfoModel.RefreshChartInfoReq
  337. if c.ShouldBind(&req) != nil {
  338. response.Fail("参数异常", c)
  339. return
  340. }
  341. chartInfoId := req.ChartInfoId
  342. if chartInfoId == 0 {
  343. response.Fail("参数有误", c)
  344. return
  345. }
  346. userInfo := user.GetInfoByClaims(c)
  347. ok, _, err := user.GetAdminByUserInfo(userInfo)
  348. if err != nil {
  349. response.FailMsg("刷新失败", "RefreshChartInfo-获取系统用户信息失败"+err.Error(), c)
  350. return
  351. }
  352. if !ok {
  353. // 普通用户刷新频率限制-每个用户/图/天/2次
  354. cacheKey := utils.HZ_CHART_LIB_DETAIL + "YB_REFRESH_LIMIT_" + strconv.Itoa(chartInfoId) + "_" + strconv.Itoa(int(userInfo.UserID))
  355. fmt.Println("refreshCacheKey:", cacheKey)
  356. countUserRefresh, _ := global.Redis.Get(context.TODO(), cacheKey).Int()
  357. if countUserRefresh >= 2 {
  358. response.Ok("目前已是最新数据", c)
  359. return
  360. }
  361. countUserRefresh += 1
  362. now := time.Now()
  363. today := time.Date(now.Year(), now.Month(), now.Day(), 23, 59, 59, 0, time.Local)
  364. sub := today.Sub(now)
  365. _ = global.Redis.SetEX(context.TODO(), cacheKey, countUserRefresh, sub)
  366. }
  367. // 图表信息校验
  368. chartInfo, err := chartInfoModel.GetChartInfoById(chartInfoId)
  369. if err != nil {
  370. if err == utils.ErrNoRow {
  371. response.Fail("图表已被删除,无需刷新", c)
  372. return
  373. }
  374. response.FailMsg("刷新失败", "刷新失败, Err:"+err.Error(), c)
  375. return
  376. }
  377. if chartInfo.Source == utils.CHART_SOURCE_CROSS_HEDGING {
  378. var config request.ChartConfigReq
  379. err = json.Unmarshal([]byte(chartInfo.ExtraConfig), &config)
  380. if err != nil {
  381. response.FailMsg("解析跨品种分析配置失败", "解析跨品种分析配置失败, Err:"+err.Error(), c)
  382. return
  383. }
  384. // 获取关联的指标信息
  385. _, _, edbInfoIdList, err := cross_variety.GetXYEdbIdList(config.TagX, config.TagY, config.VarietyList)
  386. if err != nil {
  387. response.FailMsg("获取指标信息失败", "刷新失败,获取指标信息失败, Err:"+err.Error(), c)
  388. return
  389. }
  390. // 刷新图表
  391. //_ = correlation.ChartInfoRefresh(chartInfo.ChartInfoId)
  392. err, errMsg := chart.EdbInfoRefreshAllFromBase(edbInfoIdList, false)
  393. if err != nil {
  394. errContent := fmt.Sprint("刷新图表关联指标信息失败 errMsg:", errMsg, "err: "+err.Error())
  395. if global.CONFIG.Serve.RunMode == "release" {
  396. go alarm_msg.SendAlarmMsg("刷新图表报错"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+errContent, 3)
  397. //go services.SendEmail("弘则研报小程序-release-刷新图表报错", errContent, utils.EmailSendToUsers)
  398. } else {
  399. global.LOG.Info(errContent)
  400. }
  401. response.FailMsg("刷新失败", "刷新失败,获取指标信息失败, Err:"+err.Error(), c)
  402. return
  403. }
  404. } else {
  405. // 刷新图表
  406. if err = chart.ChartInfoRefreshV2(chartInfo.ChartInfoId); err != nil {
  407. errContent := fmt.Sprint("ErrMsg: 刷新图表关联指标信息失败, " + err.Error())
  408. if global.CONFIG.Serve.RunMode == "release" {
  409. go alarm_msg.SendAlarmMsg("刷新图表报错"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+errContent, 3)
  410. //go services.SendEmail("弘则研报小程序-release-刷新图表报错", errContent, utils.EmailSendToUsers)
  411. } else {
  412. global.LOG.Info(errContent)
  413. }
  414. }
  415. }
  416. //清除图表缓存
  417. {
  418. key := utils.HZ_CHART_LIB_DETAIL + chartInfo.UniqueCode
  419. _ = global.Redis.Del(context.TODO(), key)
  420. }
  421. response.OkData("刷新成功", "", c)
  422. }
  423. // EditChartInfo 编辑图表信息
  424. // @Tags 图库模块
  425. // @Summary 编辑图表信息
  426. // @Description 编辑图表信息
  427. // @Security ApiKeyAuth
  428. // @Param Authorization header string true "Bearer 31a165baebe6dec616b1f8f3207b4273"
  429. // @Accept json
  430. // @Product json
  431. // @Param data body chartInfoModel.SaveChartInfoReq true "请求参数"
  432. // @Success 200 {string} string "操作成功"
  433. // @failure 400 {string} string "操作失败"
  434. // @Router /my_chart/editChartInfo [post]
  435. func EditChartInfo(c *gin.Context) {
  436. // 参数校验
  437. var req chartInfoModel.SaveChartInfoReq
  438. if c.ShouldBind(&req) != nil {
  439. response.Fail("参数异常", c)
  440. return
  441. }
  442. if req.ChartInfoId <= 0 {
  443. response.Fail("参数异常", c)
  444. return
  445. }
  446. // 操作权限校验
  447. userInfo := user.GetInfoByClaims(c)
  448. ok, adminInfo, err := user.GetAdminByUserInfo(userInfo)
  449. if err != nil {
  450. response.Fail("操作人信息有误", c)
  451. return
  452. }
  453. if !ok {
  454. response.Fail("非内部人员无权进行操作", c)
  455. return
  456. }
  457. // 图表信息校验
  458. chartItem, err := chartInfoModel.GetChartInfoById(req.ChartInfoId)
  459. if err != nil {
  460. if err == utils.ErrNoRow {
  461. response.Fail("图表已被删除,请刷新页面!", c)
  462. return
  463. }
  464. response.FailMsg("操作失败", "获取图表信息失败, Err:"+err.Error(), c)
  465. return
  466. }
  467. // 图表关联指标id
  468. chartEdbInfoList := make([]*chartInfoModel.ChartSaveItem, 0)
  469. // 关联指标
  470. var edbInfoIdArr []int
  471. // 非散点截面图的直接通过前端获取,散点截面图需要额外从配置中获取
  472. if chartItem.ChartType != 10 {
  473. //edbList := make([]*data_manage.EdbInfo, 0)
  474. for _, v := range req.ChartEdbInfoList {
  475. edbInfoId := v.EdbInfoId
  476. edbInfo, err := edbInfoModel.GetEdbInfoById(edbInfoId)
  477. if err != nil {
  478. if err == utils.ErrNoRow {
  479. response.FailMsg("操作失败", "图表不存在,ChartInfoId:"+strconv.Itoa(v.EdbInfoId), c)
  480. return
  481. }
  482. response.FailMsg("操作失败", "获取图表的指标信息失败,Err:"+err.Error(), c)
  483. return
  484. }
  485. if edbInfo == nil {
  486. response.FailMsg("操作失败", "指标不存在,ChartInfoId:"+strconv.Itoa(v.EdbInfoId), c)
  487. return
  488. }
  489. if edbInfo.EdbInfoId <= 0 {
  490. response.FailMsg("指标已被删除,请重新选择!", "指标不存在,ChartInfoId:"+strconv.Itoa(v.EdbInfoId), c)
  491. return
  492. }
  493. edbInfoIdArr = append(edbInfoIdArr, edbInfoId)
  494. edbInfo.EdbNameSource = edbInfo.EdbName
  495. //edbList = append(edbList, edbInfo)
  496. }
  497. chartEdbInfoList = req.ChartEdbInfoList
  498. } else {
  499. if req.ExtraConfig == `` {
  500. response.FailMsg("请选择指标!", "请选择指标!, Err:"+err.Error(), c)
  501. return
  502. }
  503. // 校验配置的指标列表
  504. tmpEdbInfoIdArr, err, errMsg := chart.CheckChartExtraConfig(chartItem.ChartType, req.ExtraConfig)
  505. if err != nil {
  506. response.FailMsg(errMsg, "修改失败!, Err:"+err.Error(), c)
  507. return
  508. }
  509. edbInfoIdArr = tmpEdbInfoIdArr
  510. lenEdbInfoIdArr := len(edbInfoIdArr)
  511. if lenEdbInfoIdArr > 0 {
  512. tmpEdbList, err := edbInfoModel.GetEdbInfoByIdList(edbInfoIdArr)
  513. if err != nil {
  514. response.FailMsg("指标异常!", "指标异常!, Err:"+err.Error(), c)
  515. return
  516. }
  517. if len(tmpEdbList) != lenEdbInfoIdArr {
  518. response.FailMsg("指标异常!", fmt.Sprint("查找出来的指标数量与选择的指标数量不符!查找出来的指标数量:", len(tmpEdbList), ";用户选择的指标数量:", lenEdbInfoIdArr), c)
  519. return
  520. }
  521. for _, v := range tmpEdbList {
  522. chartEdbInfoList = append(chartEdbInfoList, &chartInfoModel.ChartSaveItem{
  523. EdbInfoId: v.EdbInfoId,
  524. MaxData: 0,
  525. MinData: 0,
  526. IsOrder: false,
  527. IsAxis: 1,
  528. EdbInfoType: 1,
  529. LeadValue: 0,
  530. LeadUnit: "",
  531. ChartStyle: "",
  532. ChartColor: "",
  533. //PredictChartColor: "",
  534. ChartWidth: 0,
  535. Source: utils.CHART_SOURCE_DEFAULT,
  536. })
  537. }
  538. }
  539. }
  540. if len(edbInfoIdArr) <= 0 {
  541. response.Fail("请选择指标!", c)
  542. return
  543. }
  544. if chartItem.ChartType == 2 && len(req.ChartEdbInfoList) > 1 {
  545. response.Fail("您选择的图表样式为季节性图表,只支持单指标画图!", c)
  546. return
  547. }
  548. if req.Calendar == "" {
  549. req.Calendar = "公历"
  550. }
  551. sort.Ints(edbInfoIdArr)
  552. var edbInfoIdArrStr []string
  553. for _, v := range edbInfoIdArr {
  554. edbInfoIdArrStr = append(edbInfoIdArrStr, strconv.Itoa(v))
  555. }
  556. edbInfoIdStr := strings.Join(edbInfoIdArrStr, ",")
  557. err = chart.ModifyChartInfoAndMapping(edbInfoIdStr, &req, chartItem.ChartType, chartEdbInfoList)
  558. if err != nil {
  559. response.Fail("图表保存失败, Err:"+err.Error(), c)
  560. return
  561. }
  562. // 清除图表缓存
  563. cacheKey := utils.HZ_CHART_LIB_DETAIL + chartItem.UniqueCode
  564. _ = global.Redis.Del(context.TODO(), cacheKey)
  565. // 新增操作日志
  566. {
  567. chartLog := new(chart_info_log.ChartInfoLog)
  568. chartLog.ChartName = chartItem.ChartName
  569. chartLog.ChartInfoId = req.ChartInfoId
  570. chartLog.ChartClassifyId = chartItem.ChartClassifyId
  571. chartLog.SysUserId = int(adminInfo.AdminID)
  572. chartLog.SysUserRealName = adminInfo.RealName
  573. chartLog.UniqueCode = chartItem.UniqueCode
  574. chartLog.CreateTime = time.Now()
  575. bodyBytes, _ := json.Marshal(req)
  576. chartLog.Content = string(bodyBytes)
  577. chartLog.Status = "修改配置项"
  578. chartLog.Method = c.Request.URL.String()
  579. go chartLog.Create()
  580. }
  581. response.OkData("操作成功", "", c)
  582. }