chart_theme.go 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668
  1. package data
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "eta/eta_api/models/data_manage"
  6. "eta/eta_api/models/data_manage/chart_theme"
  7. "eta/eta_api/models/data_manage/chart_theme/request"
  8. "eta/eta_api/utils"
  9. "fmt"
  10. "github.com/shopspring/decimal"
  11. "math"
  12. "time"
  13. )
  14. // GetThemePreviewChartEdbData 获取图表的指标数据
  15. func GetThemePreviewChartEdbData(chartType int, calendar, startDate, endDate string, mappingList []*data_manage.ChartEdbInfoMapping, extraConfigStr string, seasonExtraConfig string) (edbList []*data_manage.ChartEdbInfoMapping, xEdbIdValue []int, yDataList []data_manage.YData, dataResp interface{}, err error, errMsg string) {
  16. edbList = make([]*data_manage.ChartEdbInfoMapping, 0)
  17. xEdbIdValue = make([]int, 0)
  18. yDataList = make([]data_manage.YData, 0)
  19. var extraConfig interface{}
  20. switch chartType {
  21. case 7: // 柱形图
  22. var barConfig data_manage.BarChartInfoReq
  23. if extraConfigStr == `` {
  24. errMsg = "柱方图未配置"
  25. err = errors.New(errMsg)
  26. return
  27. }
  28. err = json.Unmarshal([]byte(extraConfigStr), &barConfig)
  29. if err != nil {
  30. errMsg = "柱方图配置异常"
  31. err = errors.New(errMsg)
  32. return
  33. }
  34. extraConfig = barConfig
  35. case 10: // 截面散点图
  36. var tmpExtraConfig data_manage.SectionScatterReq
  37. if extraConfigStr == `` {
  38. errMsg = "截面散点图未配置"
  39. err = errors.New(errMsg)
  40. return
  41. }
  42. err = json.Unmarshal([]byte(extraConfigStr), &tmpExtraConfig)
  43. if err != nil {
  44. errMsg = "截面散点配置异常"
  45. err = errors.New(errMsg)
  46. return
  47. }
  48. extraConfig = tmpExtraConfig
  49. case utils.CHART_TYPE_RADAR:
  50. var barConfig data_manage.RadarChartInfoReq
  51. if extraConfigStr == `` {
  52. errMsg = "雷达图未配置"
  53. err = errors.New(errMsg)
  54. return
  55. }
  56. err = json.Unmarshal([]byte(extraConfigStr), &barConfig)
  57. if err != nil {
  58. errMsg = "雷达图配置异常"
  59. err = errors.New(errMsg)
  60. return
  61. }
  62. extraConfig = barConfig
  63. default:
  64. xEdbIdValue = make([]int, 0)
  65. yDataList = make([]data_manage.YData, 0)
  66. }
  67. // 指标对应的所有数据
  68. edbDataListMap, edbList, err := getThemePreviewEdbDataMapList(chartType, calendar, startDate, endDate, mappingList, seasonExtraConfig)
  69. if err != nil {
  70. return
  71. }
  72. // 特殊图形数据处理
  73. switch chartType {
  74. case 2: // 季节性图
  75. if seasonExtraConfig != "" {
  76. dataResp, err = SeasonChartData(edbList, seasonExtraConfig)
  77. } else {
  78. // 兼容无配置的老图
  79. dataResp = new(data_manage.SeasonChartResp)
  80. }
  81. case 7: // 柱形图
  82. barChartConf := extraConfig.(data_manage.BarChartInfoReq)
  83. xEdbIdValue, yDataList, err = BarChartData(mappingList, edbDataListMap, barChartConf.DateList, barChartConf.Sort)
  84. for k := range yDataList {
  85. yDataList[k].Unit = barChartConf.Unit
  86. yDataList[k].UnitEn = barChartConf.UnitEn
  87. }
  88. for _, v := range edbList {
  89. // 指标别名
  90. if barChartConf.EdbInfoIdList != nil && len(barChartConf.EdbInfoIdList) > 0 {
  91. for _, reqEdb := range barChartConf.EdbInfoIdList {
  92. if v.EdbInfoId == reqEdb.EdbInfoId {
  93. v.EdbAliasName = reqEdb.Name
  94. }
  95. }
  96. }
  97. }
  98. case 10: // 截面散点图
  99. sectionScatterConf := extraConfig.(data_manage.SectionScatterReq)
  100. xEdbIdValue, dataResp, err = getThemePreviewSectionScatterChartData(mappingList, edbDataListMap, sectionScatterConf)
  101. var tmpExtraConfig data_manage.SectionScatterReq
  102. if extraConfigStr == `` {
  103. errMsg = "截面散点图未配置"
  104. err = errors.New(errMsg)
  105. return
  106. }
  107. err = json.Unmarshal([]byte(extraConfigStr), &tmpExtraConfig)
  108. if err != nil {
  109. errMsg = "截面散点配置异常"
  110. err = errors.New(errMsg)
  111. return
  112. }
  113. // 这个数据没有必要返回给前端
  114. for _, v := range edbList {
  115. v.DataList = nil
  116. }
  117. case utils.CHART_TYPE_RADAR: //雷达图
  118. radarConf := extraConfig.(data_manage.RadarChartInfoReq)
  119. xEdbIdValue, dataResp, err = RadarChartData(mappingList, edbDataListMap, radarConf)
  120. }
  121. return
  122. }
  123. func getThemePreviewEdbDataMapList(chartType int, calendar, startDate, endDate string, mappingList []*data_manage.ChartEdbInfoMapping, seasonExtraConfig string) (edbDataListMap map[int][]*data_manage.EdbDataList, edbList []*data_manage.ChartEdbInfoMapping, err error) {
  124. // 指标对应的所有数据
  125. edbDataListMap = make(map[int][]*data_manage.EdbDataList)
  126. for _, v := range mappingList {
  127. //fmt.Println("v:", v.EdbInfoId)
  128. item := new(data_manage.ChartEdbInfoMapping)
  129. item.EdbInfoId = v.EdbInfoId
  130. item.SourceName = v.SourceName
  131. item.Source = v.Source
  132. item.EdbCode = v.EdbCode
  133. item.EdbName = v.EdbName
  134. item.EdbNameEn = v.EdbNameEn
  135. item.Frequency = v.Frequency
  136. item.EdbType = v.EdbType
  137. item.FrequencyEn = GetFrequencyEn(v.Frequency)
  138. if v.Unit != `无` {
  139. item.Unit = v.Unit
  140. }
  141. item.UnitEn = v.UnitEn
  142. item.StartDate = v.StartDate
  143. item.EndDate = v.EndDate
  144. item.ModifyTime = v.ModifyTime
  145. item.EdbInfoCategoryType = v.EdbInfoCategoryType
  146. item.PredictChartColor = v.PredictChartColor
  147. item.ClassifyId = v.ClassifyId
  148. item.IsAxis = 1
  149. item.EdbInfoType = 1
  150. item.LeadValue = v.LeadValue
  151. item.LeadUnit = v.LeadUnit
  152. item.LeadUnitEn = GetLeadUnitEn(v.LeadUnit)
  153. item.ChartEdbMappingId = v.ChartEdbMappingId
  154. item.ChartInfoId = v.ChartInfoId
  155. item.ChartStyle = v.ChartStyle
  156. item.ChartColor = v.ChartColor
  157. item.ChartWidth = 0
  158. item.IsOrder = false
  159. item.MaxData = v.MaxValue
  160. item.MinData = v.MinValue
  161. item.LatestValue = v.LatestValue
  162. item.LatestDate = v.LatestDate
  163. item.UniqueCode = v.UniqueCode
  164. item.MoveLatestDate = v.LatestDate
  165. var startDateReal string
  166. var diffSeconds int64
  167. if chartType == 2 { //季节性图
  168. startDateReal = startDate
  169. if len(mappingList) > 1 {
  170. item.IsAxis = v.IsAxis
  171. }
  172. } else {
  173. if v.EdbInfoType == 0 && v.LeadUnit != "" && v.LeadValue > 0 { //领先指标
  174. var startTimeRealTemp time.Time
  175. startDateParse, _ := time.Parse(utils.FormatDate, startDate)
  176. switch v.LeadUnit {
  177. case "天":
  178. startTimeRealTemp = startDateParse.AddDate(0, 0, -v.LeadValue)
  179. case "月":
  180. startTimeRealTemp = startDateParse.AddDate(0, -v.LeadValue, 0)
  181. case "季":
  182. startTimeRealTemp = startDateParse.AddDate(0, -3*v.LeadValue, 0)
  183. case "周":
  184. startTimeRealTemp = startDateParse.AddDate(0, 0, -7*v.LeadValue)
  185. case "年":
  186. startTimeRealTemp = startDateParse.AddDate(-v.LeadValue, 0, 0)
  187. }
  188. if startTimeRealTemp.Before(startDateParse) {
  189. startDateReal = startTimeRealTemp.Format(utils.FormatDate)
  190. diffSeconds = (int64(startTimeRealTemp.UnixNano()) - int64(startDateParse.UnixNano())) / 1e6
  191. } else {
  192. startDateReal = startDate
  193. diffSeconds = 0
  194. }
  195. // 预测指标的开始日期也要偏移
  196. {
  197. day, tmpErr := utils.GetDaysBetween2Date(utils.FormatDate, startDate, startDateReal)
  198. if tmpErr != nil {
  199. err = tmpErr
  200. return
  201. }
  202. moveLatestDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, item.MoveLatestDate, time.Local)
  203. if tmpErr != nil {
  204. err = tmpErr
  205. return
  206. }
  207. item.MoveLatestDate = moveLatestDateTime.AddDate(0, 0, day).Format(utils.FormatDate)
  208. }
  209. } else {
  210. startDateReal = startDate
  211. }
  212. }
  213. dataList := make([]*data_manage.EdbDataList, 0)
  214. dataList, err = chart_theme.GetChartThemeDefaultDataItemList(v.EdbInfoId, startDateReal)
  215. if err != nil {
  216. return
  217. }
  218. edbDataListMap[v.EdbInfoId] = dataList
  219. if diffSeconds != 0 && v.EdbInfoType == 0 {
  220. dataListLen := len(dataList)
  221. for i := 0; i < dataListLen; i++ {
  222. dataList[i].DataTimestamp = dataList[i].DataTimestamp - diffSeconds
  223. }
  224. }
  225. if chartType == 2 {
  226. latestDate, tmpErr := time.Parse(utils.FormatDate, v.LatestDate)
  227. if tmpErr != nil {
  228. //item.DataList = dataList
  229. item.IsNullData = true
  230. edbList = append(edbList, item)
  231. continue
  232. }
  233. quarterDataList, tErr := GetSeasonEdbInfoDataListByXDate(dataList, latestDate, seasonExtraConfig)
  234. if tErr != nil {
  235. err = errors.New("获取季节性图表数据失败,Err:" + tErr.Error())
  236. return
  237. }
  238. item.DataList = quarterDataList
  239. } else if chartType == 7 || chartType == utils.CHART_TYPE_RADAR { //柱方图
  240. //item.DataList = dataList
  241. } else {
  242. item.DataList = dataList
  243. }
  244. edbList = append(edbList, item)
  245. }
  246. return
  247. }
  248. func getThemePreviewSectionScatterChartData(mappingList []*data_manage.ChartEdbInfoMapping, edbDataListMap map[int][]*data_manage.EdbDataList, extraConfig data_manage.SectionScatterReq) (edbIdList []int, chartDataResp data_manage.SectionScatterInfoResp, err error) {
  249. // 指标数据数组(10086:{"2022-12-02":100.01,"2022-12-01":102.3})
  250. edbDataMap := make(map[int]map[string]float64)
  251. for edbInfoId, edbDataList := range edbDataListMap {
  252. edbDateData := make(map[string]float64)
  253. for _, edbData := range edbDataList {
  254. edbDateData[edbData.DataTime] = edbData.Value
  255. }
  256. edbDataMap[edbInfoId] = edbDateData
  257. }
  258. // edbIdList 指标展示顺序;x轴的指标顺序
  259. edbIdList = make([]int, 0)
  260. edbMappingMap := make(map[int]*data_manage.ChartEdbInfoMapping)
  261. for _, v := range mappingList {
  262. edbIdList = append(edbIdList, v.EdbInfoId)
  263. edbMappingMap[v.EdbInfoId] = v
  264. }
  265. //SectionScatterSeriesInfoResp
  266. dataListResp := make([]data_manage.SectionScatterSeriesItemResp, 0) //y轴的数据列表
  267. for _, seriesItem := range extraConfig.SeriesList {
  268. var maxDate time.Time
  269. // 系列中的指标数据
  270. tmpSeriesEdbInfoList := make([]data_manage.SectionScatterEdbItemResp, 0)
  271. var minXVal, maxXVal, minYVal, maxYVal float64
  272. for _, edbConf := range seriesItem.EdbInfoList {
  273. tmpItem := data_manage.SectionScatterEdbItemResp{
  274. IsShow: edbConf.IsShow,
  275. Name: edbConf.Name,
  276. NameEn: edbConf.NameEn,
  277. } //单个坐标点的数据
  278. //X轴的数据
  279. {
  280. edbInfoId := edbConf.XEdbInfoId //X轴的指标
  281. edbMappingInfo, ok := edbMappingMap[edbInfoId]
  282. if !ok {
  283. continue
  284. }
  285. findDate := edbConf.XDate //需要的日期值
  286. dataList := edbDataListMap[edbInfoId] //指标的所有数据值
  287. if len(dataList) <= 0 {
  288. // 没有数据的指标id
  289. //findDataList = append(findDataList, 0)
  290. continue
  291. }
  292. tmpItem.XEdbInfoId = edbInfoId
  293. tmpItem.XName = edbMappingInfo.EdbName
  294. tmpItem.XNameEn = edbMappingInfo.EdbNameEn
  295. switch edbConf.XDateType {
  296. case 1: //最新值
  297. findDate = dataList[len(dataList)-1].DataTime
  298. case 2: //近期几天
  299. findDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[len(dataList)-1].DataTime, time.Local)
  300. if tmpErr != nil {
  301. err = tmpErr
  302. return
  303. }
  304. findDateTime = findDateTime.AddDate(0, 0, -edbConf.XDateValue)
  305. lenData := len(dataList) - 1
  306. for i := lenData; i >= 0; i-- {
  307. currDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[i].DataTime, time.Local)
  308. if tmpErr != nil {
  309. err = tmpErr
  310. return
  311. }
  312. if currDateTime.Equal(findDateTime) || currDateTime.Before(findDateTime) {
  313. findDate = dataList[i].DataTime
  314. break
  315. }
  316. }
  317. case 3: // 固定日期
  318. //最早的日期
  319. minDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[0].DataTime, time.Local)
  320. if tmpErr != nil {
  321. err = tmpErr
  322. return
  323. }
  324. //寻找固定日期的数据
  325. findDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, edbConf.XDate, time.Local)
  326. if tmpErr != nil {
  327. err = tmpErr
  328. return
  329. }
  330. for tmpDateTime := findDateTime; tmpDateTime.After(minDateTime) || tmpDateTime.Equal(minDateTime); tmpDateTime = tmpDateTime.AddDate(0, 0, -1) {
  331. tmpDate := tmpDateTime.Format(utils.FormatDate)
  332. if _, ok := edbDataMap[edbInfoId][tmpDate]; ok { //如果能找到数据,那么就返回
  333. findDate = tmpDate
  334. break
  335. }
  336. }
  337. default:
  338. err = errors.New(fmt.Sprint("日期类型异常,Type:", edbConf.XDate))
  339. return
  340. }
  341. findDateTime, _ := time.ParseInLocation(utils.FormatDate, findDate, time.Local)
  342. if maxDate.IsZero() {
  343. maxDate = findDateTime
  344. } else {
  345. if findDateTime.After(maxDate) {
  346. maxDate = findDateTime
  347. }
  348. }
  349. if tmpValue, ok := edbDataMap[edbInfoId][findDate]; ok {
  350. tmpItem.XDate = findDate
  351. tmpItem.XValue = tmpValue
  352. } else {
  353. continue
  354. }
  355. }
  356. //Y轴的数据
  357. {
  358. edbInfoId := edbConf.YEdbInfoId //Y轴的指标
  359. edbMappingInfo, ok := edbMappingMap[edbInfoId]
  360. if !ok {
  361. continue
  362. }
  363. findDate := edbConf.YDate //需要的日期值
  364. dataList := edbDataListMap[edbInfoId] //指标的所有数据值
  365. if len(dataList) <= 0 {
  366. // 没有数据的指标id
  367. //findDataList = append(findDataList, 0)
  368. continue
  369. }
  370. tmpItem.YEdbInfoId = edbInfoId
  371. tmpItem.YName = edbMappingInfo.EdbName
  372. tmpItem.YNameEn = edbMappingInfo.EdbNameEn
  373. switch edbConf.YDateType {
  374. case 1: //最新值
  375. findDate = dataList[len(dataList)-1].DataTime
  376. case 2: //近期几天
  377. findDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[len(dataList)-1].DataTime, time.Local)
  378. if tmpErr != nil {
  379. err = tmpErr
  380. return
  381. }
  382. findDateTime = findDateTime.AddDate(0, 0, -edbConf.YDateValue)
  383. lenData := len(dataList) - 1
  384. for i := lenData; i >= 0; i-- {
  385. currDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[i].DataTime, time.Local)
  386. if tmpErr != nil {
  387. err = tmpErr
  388. return
  389. }
  390. if currDateTime.Equal(findDateTime) || currDateTime.Before(findDateTime) {
  391. findDate = dataList[i].DataTime
  392. break
  393. }
  394. }
  395. case 3: // 固定日期
  396. //最早的日期
  397. minDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[0].DataTime, time.Local)
  398. if tmpErr != nil {
  399. err = tmpErr
  400. return
  401. }
  402. //寻找固定日期的数据
  403. findDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, edbConf.YDate, time.Local)
  404. if tmpErr != nil {
  405. err = tmpErr
  406. return
  407. }
  408. for tmpDateTime := findDateTime; tmpDateTime.After(minDateTime) || tmpDateTime.Equal(minDateTime); tmpDateTime = tmpDateTime.AddDate(0, 0, -1) {
  409. tmpDate := tmpDateTime.Format(utils.FormatDate)
  410. if _, ok := edbDataMap[edbInfoId][tmpDate]; ok { //如果能找到数据,那么就返回
  411. findDate = tmpDate
  412. break
  413. }
  414. }
  415. default:
  416. err = errors.New(fmt.Sprint("日期类型异常,Type:", edbConf.YDate))
  417. return
  418. }
  419. findDateTime, _ := time.ParseInLocation(utils.FormatDate, findDate, time.Local)
  420. if maxDate.IsZero() {
  421. maxDate = findDateTime
  422. } else {
  423. if findDateTime.After(maxDate) {
  424. maxDate = findDateTime
  425. }
  426. }
  427. if tmpValue, ok := edbDataMap[edbInfoId][findDate]; ok {
  428. tmpItem.YDate = findDate
  429. tmpItem.YValue = tmpValue
  430. } else {
  431. continue
  432. }
  433. }
  434. // 获取当前系列的X轴的最大最小值
  435. {
  436. if tmpItem.XValue < minXVal {
  437. minXVal = tmpItem.XValue
  438. }
  439. if tmpItem.XValue > maxXVal {
  440. maxXVal = tmpItem.XValue
  441. }
  442. if tmpItem.YValue < minYVal {
  443. minYVal = tmpItem.YValue
  444. }
  445. if tmpItem.YValue > maxYVal {
  446. maxYVal = tmpItem.YValue
  447. }
  448. }
  449. tmpSeriesEdbInfoList = append(tmpSeriesEdbInfoList, tmpItem)
  450. }
  451. trendLimitData := make([]data_manage.CoordinatePoint, 0) //趋势线的前后坐标点
  452. var trendLine, rSquare string
  453. // 生成线性方程式
  454. var a, b float64
  455. {
  456. coordinateData := make([]utils.Coordinate, 0)
  457. for _, tmpSeriesEdbInfo := range tmpSeriesEdbInfoList {
  458. tmpCoordinate1 := utils.Coordinate{
  459. X: tmpSeriesEdbInfo.XValue,
  460. Y: tmpSeriesEdbInfo.YValue,
  461. }
  462. coordinateData = append(coordinateData, tmpCoordinate1)
  463. }
  464. // 只有存在两个坐标点的时候,才能去计算线性方程和R平方
  465. if len(coordinateData) >= 2 {
  466. a, b = utils.GetLinearResult(coordinateData)
  467. if !math.IsNaN(a) && !math.IsNaN(b) {
  468. if b > 0 {
  469. trendLine = fmt.Sprintf("y=%sx+%s", utils.SubFloatToString(a, 4), utils.SubFloatToString(b, 4))
  470. } else {
  471. trendLine = fmt.Sprintf("y=%sx%s", utils.SubFloatToString(a, 4), utils.SubFloatToString(b, 4))
  472. }
  473. minYVal, _ = decimal.NewFromFloat(a).Mul(decimal.NewFromFloat(minXVal)).Add(decimal.NewFromFloat(b)).Round(4).Float64()
  474. maxYVal, _ = decimal.NewFromFloat(a).Mul(decimal.NewFromFloat(maxXVal)).Add(decimal.NewFromFloat(b)).Round(4).Float64()
  475. }
  476. // 计算R平方
  477. rSquare = fmt.Sprint(utils.CalculationDecisive(coordinateData))
  478. }
  479. trendLimitData = append(trendLimitData, data_manage.CoordinatePoint{
  480. X: minXVal,
  481. Y: minYVal,
  482. }, data_manage.CoordinatePoint{
  483. X: maxXVal,
  484. Y: maxYVal,
  485. })
  486. }
  487. dataListResp = append(dataListResp, data_manage.SectionScatterSeriesItemResp{
  488. Name: seriesItem.Name,
  489. NameEn: seriesItem.NameEn,
  490. IsNameDefault: seriesItem.IsNameDefault,
  491. Color: seriesItem.Color,
  492. EdbInfoList: tmpSeriesEdbInfoList,
  493. ShowTrendLine: seriesItem.ShowTrendLine,
  494. ShowFitEquation: seriesItem.ShowFitEquation,
  495. ShowRSquare: seriesItem.ShowRSquare,
  496. TrendLine: trendLine,
  497. RSquare: rSquare,
  498. TrendLimitData: trendLimitData,
  499. })
  500. }
  501. // 截面散点图点击详情时自动更新系列名
  502. if len(extraConfig.SeriesList) > 0 {
  503. // 默认名字的时候才自动更新
  504. if extraConfig.SeriesList[0].IsNameDefault {
  505. firstXEdbInfoId := extraConfig.SeriesList[0].EdbInfoList[0].XEdbInfoId
  506. if v, ok := edbMappingMap[firstXEdbInfoId]; ok {
  507. extraConfig.SeriesList[0].Name = v.LatestDate
  508. extraConfig.SeriesList[0].NameEn = v.LatestDate
  509. dataListResp[0].Name = v.LatestDate
  510. dataListResp[0].NameEn = v.LatestDate
  511. }
  512. }
  513. }
  514. chartDataResp = data_manage.SectionScatterInfoResp{
  515. XName: extraConfig.XName,
  516. XNameEn: extraConfig.XNameEn,
  517. XUnitName: extraConfig.XUnitName,
  518. XUnitNameEn: extraConfig.XUnitNameEn,
  519. YName: extraConfig.YName,
  520. YNameEn: extraConfig.YNameEn,
  521. YUnitName: extraConfig.YUnitName,
  522. YUnitNameEn: extraConfig.YUnitNameEn,
  523. XMinValue: extraConfig.XMinValue,
  524. XMaxValue: extraConfig.XMaxValue,
  525. YMinValue: extraConfig.YMinValue,
  526. YMaxValue: extraConfig.YMaxValue,
  527. DataList: dataListResp,
  528. }
  529. return
  530. }
  531. // GetChartThemeConfig
  532. // @Description: 根据主题id获取主题信息,如果获取不到的话,那么就获取默认的主题
  533. // @author: Roc
  534. // @datetime 2023-12-19 14:31:17
  535. // @param chartThemeId int
  536. // @param chartType int
  537. // @param source int
  538. // @return chartTheme *chart_theme.ChartTheme
  539. // @return err error
  540. func GetChartThemeConfig(chartThemeId, source, chartType int) (chartTheme *chart_theme.ChartTheme, err error) {
  541. chartTheme, err = chart_theme.GetChartThemeId(chartThemeId)
  542. if err != nil && err.Error() != utils.ErrNoRow() {
  543. return
  544. }
  545. err = nil
  546. // 如果找到了,那么就返回
  547. if chartTheme != nil {
  548. // 兼容历史数据,加入新字段LineOptionList
  549. newConfig, e := ConvertOldChartOptions(chartTheme.Config)
  550. if e == nil {
  551. chartTheme.Config = newConfig
  552. }
  553. return
  554. }
  555. // 没有找到的话,那么就找默认的主题
  556. // 查找主题类型id
  557. chartThemeType, err := chart_theme.GetChartThemeTypeByChartTypeAndSource(chartType, source)
  558. if err != nil {
  559. return
  560. }
  561. // 寻找默认的主题id
  562. chartTheme, err = chart_theme.GetChartThemeId(chartThemeType.DefaultChartThemeId)
  563. if err != nil && err.Error() != utils.ErrNoRow() {
  564. return
  565. }
  566. err = nil
  567. // 如果找到了,那么就返回
  568. if chartTheme != nil {
  569. // 兼容历史数据,加入新字段LineOptionList
  570. newConfig, e := ConvertOldChartOptions(chartTheme.Config)
  571. if e == nil {
  572. chartTheme.Config = newConfig
  573. }
  574. return
  575. }
  576. // 如果还是没找到,那就系统的主题id
  577. chartTheme, err = chart_theme.GetSystemChartTheme(chartThemeType.ChartThemeTypeId)
  578. // 兼容历史数据,加入新字段LineOptionList
  579. newConfig, e := ConvertOldChartOptions(chartTheme.Config)
  580. if e == nil {
  581. chartTheme.Config = newConfig
  582. }
  583. return
  584. }
  585. // 兼容历史数据,加入新字段LineOptionList
  586. func ConvertOldChartOptions(config string) (newConfig string, err error) {
  587. var oldTheme request.OldChartOptions
  588. var newTheme request.NewChartOptions
  589. err = json.Unmarshal([]byte(config), &oldTheme)
  590. if err != nil {
  591. return
  592. }
  593. if oldTheme.LineOptionList != nil && len(oldTheme.LineOptionList) > 0 {
  594. newConfig = config
  595. return
  596. }
  597. newTheme.OldChartOptions = oldTheme
  598. for i := 0; i < 10; i++ {
  599. newLineOption := request.NewLineOptions{
  600. LineOptions: oldTheme.LineOptions,
  601. Color: oldTheme.ColorsOptions[i],
  602. DataMark: "none",
  603. MarkType: "square",
  604. MarkSize: 5,
  605. MarkColor: oldTheme.ColorsOptions[i],
  606. }
  607. newTheme.LineOptionList = append(newTheme.LineOptionList, newLineOption)
  608. }
  609. newThemeStr, _ := json.Marshal(newTheme)
  610. newConfig = string(newThemeStr)
  611. return
  612. }