chart_extra_config.go 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826
  1. package data
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "eta/eta_api/models/data_manage"
  6. "eta/eta_api/services/google"
  7. "eta/eta_api/utils"
  8. "fmt"
  9. "strconv"
  10. "strings"
  11. "time"
  12. )
  13. func HandleExtraConfig(chartType int, extraConfigStr string) (newExtraConfigStr string, newAllExtraConfigStr string, err error, errMsg string) {
  14. newExtraConfigStr = extraConfigStr
  15. switch chartType {
  16. case 10: // 截面散点图
  17. var tmpExtraConfig data_manage.SectionScatterReq
  18. if extraConfigStr == `` {
  19. errMsg = "截面散点图未配置"
  20. err = errors.New(errMsg)
  21. return
  22. }
  23. err = json.Unmarshal([]byte(extraConfigStr), &tmpExtraConfig)
  24. if err != nil {
  25. errMsg = "截面散点配置异常"
  26. err = errors.New(errMsg)
  27. return
  28. }
  29. newExtraConfigStr, err, errMsg = handleSectionScatterChartData(tmpExtraConfig)
  30. case utils.CHART_TYPE_SECTION_COMBINE:
  31. //整理组合图的配置信息,将部分信息存入其他表
  32. // 预览和详情都走这个接口
  33. var sectionExtraConfig data_manage.ChartSectionAllExtraConf
  34. if extraConfigStr == `` {
  35. errMsg = "截面组合图未配置"
  36. err = errors.New(errMsg)
  37. return
  38. }
  39. err = json.Unmarshal([]byte(extraConfigStr), &sectionExtraConfig)
  40. if err != nil {
  41. errMsg = "截面组合图配置异常"
  42. err = errors.New(errMsg)
  43. return
  44. }
  45. newAllExtraConfig, e, msg := handleChartSectionCombineData(sectionExtraConfig)
  46. if e != nil {
  47. err = e
  48. errMsg = msg
  49. return
  50. }
  51. newAllExtraConfigByte, e := json.Marshal(newAllExtraConfig)
  52. if e != nil {
  53. err = e
  54. return
  55. }
  56. newAllExtraConfigStr = string(newAllExtraConfigByte)
  57. newExtraConfig := &data_manage.ChartSectionExtraConf{
  58. DateConfList: newAllExtraConfig.DateConfList,
  59. IsHeap: newAllExtraConfig.IsHeap,
  60. XDataList: newAllExtraConfig.XDataList,
  61. UnitList: newAllExtraConfig.UnitList,
  62. BaseChartSeriesName: newAllExtraConfig.BaseChartSeriesName,
  63. SortType: newAllExtraConfig.SortType,
  64. }
  65. extraConfigByte, e := json.Marshal(newExtraConfig)
  66. if e != nil {
  67. err = e
  68. return
  69. }
  70. newExtraConfigStr = string(extraConfigByte)
  71. }
  72. return
  73. }
  74. // handleSectionScatterChartData 截面散点图的数据处理
  75. func handleSectionScatterChartData(extraConfig data_manage.SectionScatterReq) (extraConfigStr string, err error, errMsg string) {
  76. translateNameList := make([]string, 0)
  77. translateNameMap := make(map[string]bool, 0)
  78. if extraConfig.XNameEn == `` {
  79. if _, ok := translateNameMap[extraConfig.XName]; !ok {
  80. translateNameMap[extraConfig.XName] = true
  81. tmpName := strings.TrimSuffix(extraConfig.XName, " ")
  82. tmpName = strings.TrimPrefix(tmpName, " ")
  83. translateNameList = append(translateNameList, tmpName)
  84. }
  85. }
  86. if extraConfig.XUnitNameEn == `` {
  87. if _, ok := translateNameMap[extraConfig.XUnitName]; !ok {
  88. translateNameMap[extraConfig.XUnitName] = true
  89. tmpName := strings.TrimSuffix(extraConfig.XUnitName, " ")
  90. tmpName = strings.TrimPrefix(tmpName, " ")
  91. translateNameList = append(translateNameList, tmpName)
  92. }
  93. }
  94. if extraConfig.YNameEn == `` {
  95. if _, ok := translateNameMap[extraConfig.YName]; !ok {
  96. translateNameMap[extraConfig.YName] = true
  97. tmpName := strings.TrimSuffix(extraConfig.YName, " ")
  98. tmpName = strings.TrimPrefix(tmpName, " ")
  99. translateNameList = append(translateNameList, tmpName)
  100. }
  101. }
  102. if extraConfig.YUnitNameEn == `` {
  103. if _, ok := translateNameMap[extraConfig.YUnitName]; !ok {
  104. translateNameMap[extraConfig.YUnitName] = true
  105. tmpName := strings.TrimSuffix(extraConfig.YUnitName, " ")
  106. tmpName = strings.TrimPrefix(tmpName, " ")
  107. translateNameList = append(translateNameList, tmpName)
  108. }
  109. }
  110. for _, v := range extraConfig.SeriesList {
  111. if v.NameEn == `` {
  112. if _, ok := translateNameMap[v.Name]; !ok {
  113. translateNameMap[v.Name] = true
  114. tmpName := strings.TrimSuffix(v.Name, " ")
  115. tmpName = strings.TrimPrefix(tmpName, " ")
  116. translateNameList = append(translateNameList, tmpName)
  117. }
  118. }
  119. for _, edbInfo := range v.EdbInfoList {
  120. if edbInfo.NameEn == `` {
  121. if _, ok := translateNameMap[edbInfo.Name]; !ok {
  122. translateNameMap[edbInfo.Name] = true
  123. tmpName := strings.TrimSuffix(edbInfo.Name, " ")
  124. tmpName = strings.TrimPrefix(tmpName, " ")
  125. translateNameList = append(translateNameList, tmpName)
  126. }
  127. }
  128. }
  129. }
  130. // 获取英文名称map
  131. enNameMap, _, _ := GetEnNameMapByCnNameList(translateNameList)
  132. for k, seriesItem := range extraConfig.SeriesList {
  133. if len(seriesItem.EdbInfoList) <= 0 {
  134. errMsg = "指标不能为空"
  135. err = errors.New(errMsg)
  136. return
  137. }
  138. for edbIndex, edbConf := range seriesItem.EdbInfoList {
  139. if edbConf.NameEn == `` { //标签英文名称
  140. if tmpNameEn, ok := enNameMap[edbConf.Name]; ok {
  141. edbConf.NameEn = tmpNameEn
  142. }
  143. }
  144. seriesItem.EdbInfoList[edbIndex] = edbConf
  145. }
  146. if seriesItem.NameEn == `` { //系列英文名称
  147. if tmpNameEn, ok := enNameMap[seriesItem.Name]; ok {
  148. seriesItem.NameEn = tmpNameEn
  149. }
  150. }
  151. extraConfig.SeriesList[k] = seriesItem
  152. }
  153. if extraConfig.XNameEn == `` {
  154. if tmpNameEn, ok := enNameMap[extraConfig.XName]; ok {
  155. extraConfig.XNameEn = tmpNameEn
  156. }
  157. }
  158. if extraConfig.XUnitNameEn == `` {
  159. if tmpNameEn, ok := enNameMap[extraConfig.XUnitName]; ok {
  160. extraConfig.XUnitNameEn = tmpNameEn
  161. }
  162. }
  163. if extraConfig.YNameEn == `` {
  164. if tmpNameEn, ok := enNameMap[extraConfig.YName]; ok {
  165. extraConfig.YNameEn = tmpNameEn
  166. }
  167. }
  168. if extraConfig.YUnitNameEn == `` {
  169. if tmpNameEn, ok := enNameMap[extraConfig.YUnitName]; ok {
  170. extraConfig.YUnitNameEn = tmpNameEn
  171. }
  172. }
  173. extraConfigByte, err := json.Marshal(extraConfig)
  174. if err != nil {
  175. return
  176. }
  177. extraConfigStr = string(extraConfigByte)
  178. return
  179. }
  180. // GetEnNameMapByCnNameList 根据中文名称列表获取英文名称map
  181. func GetEnNameMapByCnNameList(cnNameList []string) (contentEnMap map[string]string, err error, errMsg string) {
  182. // 返回参初始化
  183. contentEnMap = make(map[string]string)
  184. // 英文临时赋值变量
  185. tmpContentEnMapAll := make(map[string]string)
  186. count := 0
  187. contentMap := make(map[string]string, 0)
  188. for k, v := range cnNameList {
  189. //如果单条翻译的字符数超过1000,则直接翻译,否则批量翻译
  190. if count >= 50 { //待翻译的条数不能超过50; 单条翻译字符数不能超过1000字符
  191. tmpContentEnMap, tmpErr, tmpErrMsg := google.BatchTranslateHandlerByGoogle(contentMap)
  192. if tmpErr != nil {
  193. err = tmpErr
  194. errMsg = tmpErrMsg
  195. return
  196. }
  197. for tmpK, contentEn := range tmpContentEnMap {
  198. tmpContentEnMapAll[tmpK] = contentEn
  199. }
  200. contentMap = make(map[string]string, 0)
  201. count = 0
  202. }
  203. contentMap[strconv.Itoa(k)] = v
  204. count += 1
  205. }
  206. //剩余不满50条的content
  207. if count > 0 {
  208. tmpContentEnMap, tmpErr, tmpErrMsg := google.BatchTranslateHandlerByGoogle(contentMap)
  209. if tmpErr != nil {
  210. err = tmpErr
  211. errMsg = tmpErrMsg
  212. return
  213. }
  214. for tmpK, contentEn := range tmpContentEnMap {
  215. tmpContentEnMapAll[tmpK] = contentEn
  216. }
  217. }
  218. // 重新组装拼接返回
  219. lenCnNameList := len(cnNameList)
  220. for k, v := range tmpContentEnMapAll {
  221. tmpIndex, _ := strconv.Atoi(k)
  222. if tmpIndex < lenCnNameList {
  223. contentEnMap[cnNameList[tmpIndex]] = v
  224. }
  225. }
  226. return
  227. }
  228. // handleSectionScatterChartData 截面组合图的数据处理
  229. func handleChartSectionCombineData(extraConfig data_manage.ChartSectionAllExtraConf) (newExtraConfig data_manage.ChartSectionAllExtraConf, err error, errMsg string) {
  230. translateNameList := make([]string, 0)
  231. translateNameMap := make(map[string]bool, 0)
  232. for _, v := range extraConfig.DateConfList {
  233. if _, ok := translateNameMap[v.DateConfName]; !ok && v.DateConfNameEn == "" {
  234. translateNameMap[v.DateConfName] = true
  235. tmpName := strings.TrimSuffix(v.DateConfName, " ")
  236. tmpName = strings.TrimPrefix(tmpName, " ")
  237. translateNameList = append(translateNameList, tmpName)
  238. }
  239. }
  240. if _, ok := translateNameMap[extraConfig.UnitList.LeftName]; !ok && extraConfig.UnitList.LeftNameEn == "" {
  241. translateNameMap[extraConfig.UnitList.LeftName] = true
  242. tmpName := strings.TrimSuffix(extraConfig.UnitList.LeftName, " ")
  243. tmpName = strings.TrimPrefix(tmpName, " ")
  244. translateNameList = append(translateNameList, tmpName)
  245. }
  246. if _, ok := translateNameMap[extraConfig.UnitList.RightName]; !ok && extraConfig.UnitList.RightNameEn == "" {
  247. translateNameMap[extraConfig.UnitList.RightName] = true
  248. tmpName := strings.TrimSuffix(extraConfig.UnitList.RightName, " ")
  249. tmpName = strings.TrimPrefix(tmpName, " ")
  250. translateNameList = append(translateNameList, tmpName)
  251. }
  252. if _, ok := translateNameMap[extraConfig.UnitList.RightTwoName]; !ok && extraConfig.UnitList.RightTwoNameEn == "" {
  253. translateNameMap[extraConfig.UnitList.RightTwoName] = true
  254. tmpName := strings.TrimSuffix(extraConfig.UnitList.RightTwoName, " ")
  255. tmpName = strings.TrimPrefix(tmpName, " ")
  256. translateNameList = append(translateNameList, tmpName)
  257. }
  258. for _, v := range extraConfig.XDataList {
  259. if _, ok := translateNameMap[v.Name]; !ok && v.NameEn == "" {
  260. translateNameMap[v.Name] = true
  261. tmpName := strings.TrimSuffix(v.Name, " ")
  262. tmpName = strings.TrimPrefix(tmpName, " ")
  263. translateNameList = append(translateNameList, tmpName)
  264. }
  265. }
  266. for _, v := range extraConfig.SeriesList {
  267. if v.SeriesNameEn == `` {
  268. if _, ok := translateNameMap[v.SeriesName]; !ok {
  269. translateNameMap[v.SeriesName] = true
  270. tmpName := strings.TrimSuffix(v.SeriesName, " ")
  271. tmpName = strings.TrimPrefix(tmpName, " ")
  272. translateNameList = append(translateNameList, tmpName)
  273. }
  274. }
  275. }
  276. // 获取英文名称map
  277. enNameMap, _, _ := GetEnNameMapByCnNameList(translateNameList)
  278. for k, seriesItem := range extraConfig.SeriesList {
  279. if len(seriesItem.EdbInfoList) <= 0 {
  280. errMsg = "指标不能为空"
  281. err = errors.New(errMsg)
  282. return
  283. }
  284. if seriesItem.SeriesNameEn == `` { //系列英文名称
  285. if tmpNameEn, ok := enNameMap[seriesItem.SeriesName]; ok {
  286. seriesItem.SeriesNameEn = tmpNameEn
  287. }
  288. }
  289. extraConfig.SeriesList[k] = seriesItem
  290. }
  291. for k, v := range extraConfig.XDataList {
  292. if tmpNameEn, ok := enNameMap[v.Name]; ok && v.NameEn == "" {
  293. extraConfig.XDataList[k].NameEn = tmpNameEn
  294. }
  295. }
  296. if tmpNameEn, ok := enNameMap[extraConfig.UnitList.LeftName]; ok && extraConfig.UnitList.LeftNameEn == "" {
  297. extraConfig.UnitList.LeftName = tmpNameEn
  298. }
  299. if tmpNameEn, ok := enNameMap[extraConfig.UnitList.RightName]; ok && extraConfig.UnitList.RightNameEn == "" {
  300. extraConfig.UnitList.RightName = tmpNameEn
  301. }
  302. if tmpNameEn, ok := enNameMap[extraConfig.UnitList.RightTwoName]; ok && extraConfig.UnitList.RightTwoNameEn == "" {
  303. extraConfig.UnitList.RightTwoName = tmpNameEn
  304. }
  305. for k, v := range extraConfig.DateConfList {
  306. if tmpNameEn, ok := enNameMap[v.DateConfName]; ok && v.DateConfNameEn == "" {
  307. extraConfig.DateConfList[k].DateConfNameEn = tmpNameEn
  308. }
  309. }
  310. newExtraConfig = extraConfig
  311. return
  312. }
  313. // GetChartSectionCombineData 截面组合图的数据处理
  314. func GetChartSectionCombineData(chartInfo *data_manage.ChartInfo, mappingList []*data_manage.ChartEdbInfoMapping, edbDataListMap map[int][]*data_manage.EdbDataList, extraConfig data_manage.ChartSectionAllExtraConf) (edbIdList []int, dataListResp data_manage.ChartSectionCombineDataResp, err error) {
  315. // 指标数据数组(10086:{"2022-12-02":100.01,"2022-12-01":102.3})
  316. edbDataMap := make(map[int]map[string]float64)
  317. for edbInfoId, edbDataList := range edbDataListMap {
  318. edbDateData := make(map[string]float64)
  319. for _, edbData := range edbDataList {
  320. edbDateData[edbData.DataTime] = edbData.Value
  321. }
  322. edbDataMap[edbInfoId] = edbDateData
  323. }
  324. // edbIdList 指标展示顺序;x轴的指标顺序
  325. edbIdList = make([]int, 0)
  326. edbMappingMap := make(map[int]*data_manage.ChartEdbInfoMapping)
  327. for _, v := range mappingList {
  328. edbIdList = append(edbIdList, v.EdbInfoId)
  329. edbMappingMap[v.EdbInfoId] = v
  330. }
  331. // 确定好截面散点图返回的数据格式
  332. // 获取所有的引用日期设置
  333. dateConfListMap := make(map[string]*data_manage.ChartSectionDateConfItem)
  334. dateConfEdbIds := make([]int, 0)
  335. for _, v := range extraConfig.DateConfList {
  336. if v.EdbInfoId > 0 {
  337. dateConfEdbIds = append(dateConfEdbIds, v.EdbInfoId)
  338. }
  339. dateConfListMap[v.DateConfName] = v
  340. }
  341. // 遍历每个系列
  342. // 遍历每个指标,根据选中的日期,进行日期变换得到最终的日期,根据最终的日期获取对应的值
  343. // 组装数据
  344. baseSeries := new(data_manage.ChartSectionSeriesItem) //y轴的系列
  345. var firstUnit, leftUnit, rightUnit, right2Unit *data_manage.XData
  346. var (
  347. LeftMin float64
  348. LeftMax float64
  349. RightMin float64
  350. RightMax float64
  351. Right2Min float64
  352. Right2Max float64
  353. )
  354. for _, seriesItem := range extraConfig.SeriesList {
  355. var maxDate time.Time
  356. var minVal, maxVal float64
  357. noDataEdbIdList := make([]int, 0)
  358. dataList := make([]float64, len(seriesItem.EdbInfoList))
  359. for index, edbConf := range seriesItem.EdbInfoList {
  360. edbInfoId := edbConf.EdbInfoId //X轴的指标
  361. edbMappingInfo, ok := edbMappingMap[edbInfoId]
  362. if !ok {
  363. continue
  364. }
  365. seriesItem.EdbInfoList[index].EdbName = edbMappingInfo.EdbName
  366. seriesItem.EdbInfoList[index].EdbNameEn = edbMappingInfo.EdbNameEn
  367. seriesItem.EdbInfoList[index].EdbInfoType = edbMappingInfo.EdbInfoType
  368. seriesItem.EdbInfoList[index].Unit = edbMappingInfo.Unit
  369. seriesItem.EdbInfoList[index].UnitEn = edbMappingInfo.UnitEn
  370. if index == 0 {
  371. firstUnit = &data_manage.XData{
  372. Name: edbMappingInfo.Unit,
  373. NameEn: edbMappingInfo.UnitEn,
  374. }
  375. }
  376. edbDataList, ok3 := edbDataListMap[edbInfoId]
  377. if !ok3 {
  378. err = fmt.Errorf("指标%d的日期数据不存在", edbInfoId)
  379. return
  380. }
  381. //日期变换处理,判断用指标的最新日期还是,直接获取引用日期
  382. var findDate string
  383. if edbConf.DateConfType == 0 {
  384. if edbInfoId == 0 {
  385. err = fmt.Errorf("请选择指标")
  386. return
  387. }
  388. findDate, err = GetChartSectionSeriesDateByDateChange(edbInfoId, edbDataList, edbConf.DateConf.DateChange, edbConf.DateConf.MoveForward)
  389. if err != nil {
  390. err = fmt.Errorf("指标%d的日期变换处理失败", edbInfoId)
  391. return
  392. }
  393. } else {
  394. // 获取日期配置
  395. dateConfItem, ok1 := dateConfListMap[edbConf.DateConfName]
  396. if !ok1 {
  397. err = fmt.Errorf("引用日期配置不存在")
  398. return
  399. }
  400. // todo 根据日期变换得到最终日期
  401. edbDataListTmp := make([]*data_manage.EdbDataList, 0)
  402. if dateConfItem.EdbInfoId > 0 {
  403. edbDataListTmp, ok1 = edbDataListMap[dateConfItem.EdbInfoId]
  404. if !ok1 {
  405. err = fmt.Errorf("指标%d的日期数据不存在", dateConfItem.EdbInfoId)
  406. return
  407. }
  408. }
  409. findDate, err = GetChartSectionSeriesDateByDateChange(dateConfItem.EdbInfoId, edbDataListTmp, dateConfItem.DateChange, dateConfItem.MoveForward)
  410. if err != nil {
  411. err = fmt.Errorf("指标%d的日期变换处理失败", dateConfItem.EdbInfoId)
  412. return
  413. }
  414. }
  415. findDateTime, _ := time.ParseInLocation(utils.FormatDate, findDate, time.Local)
  416. if maxDate.IsZero() {
  417. maxDate = findDateTime
  418. } else {
  419. if findDateTime.After(maxDate) {
  420. maxDate = findDateTime
  421. }
  422. }
  423. if tmpValue, ok := edbDataMap[edbInfoId][findDate]; ok {
  424. dataList[index] = tmpValue
  425. if index == 0 {
  426. minVal = tmpValue
  427. maxVal = tmpValue
  428. } else {
  429. if tmpValue < minVal {
  430. minVal = tmpValue
  431. }
  432. if tmpValue > maxVal {
  433. maxVal = tmpValue
  434. }
  435. }
  436. } else {
  437. noDataEdbIdList = append(noDataEdbIdList, edbInfoId)
  438. continue
  439. }
  440. }
  441. seriesItem.DataList = dataList
  442. seriesItem.MinData = minVal
  443. seriesItem.MaxData = maxVal
  444. seriesItem.NoDataEdbIdList = noDataEdbIdList
  445. if extraConfig.BaseChartSeriesName == seriesItem.SeriesName {
  446. baseSeries = seriesItem
  447. }
  448. if seriesItem.IsAxis == 1 && leftUnit == nil { //左轴,右轴
  449. leftUnit = firstUnit
  450. } else if seriesItem.IsAxis == 0 && rightUnit == nil {
  451. rightUnit = firstUnit
  452. } else if seriesItem.IsAxis == 2 && right2Unit == nil {
  453. right2Unit = firstUnit
  454. }
  455. //处理上下限
  456. var minData, maxData float64
  457. for _, d := range seriesItem.DataList {
  458. if minData > d {
  459. minData = d
  460. }
  461. if maxData < d {
  462. maxData = d
  463. }
  464. }
  465. if seriesItem.IsAxis == 1 {
  466. if LeftMin > minData {
  467. LeftMin = minData
  468. }
  469. if LeftMax < maxData {
  470. LeftMax = maxData
  471. }
  472. } else if seriesItem.IsAxis == 0 {
  473. if RightMin > minData {
  474. RightMin = minData
  475. }
  476. if RightMax < maxData {
  477. RightMax = maxData
  478. }
  479. } else {
  480. if Right2Min > minData {
  481. Right2Min = minData
  482. }
  483. if Right2Max < maxData {
  484. Right2Max = maxData
  485. }
  486. }
  487. }
  488. // 处理横轴
  489. // 遍历基准系列,判断有几个横轴名称
  490. if baseSeries == nil {
  491. err = fmt.Errorf("基准系列不存在")
  492. return
  493. }
  494. xDataList := make([]data_manage.XData, 0)
  495. for index, item := range baseSeries.EdbInfoList {
  496. if index == 0 {
  497. firstUnit = &data_manage.XData{
  498. Name: item.Unit,
  499. NameEn: item.UnitEn,
  500. }
  501. }
  502. tmp := data_manage.XData{
  503. Name: item.EdbName,
  504. NameEn: item.EdbNameEn,
  505. }
  506. // 如果已经设置了横轴名称,则用设置的名称替换
  507. if len(extraConfig.XDataList) > index {
  508. newItem := extraConfig.XDataList[index]
  509. if newItem.Name != "" {
  510. tmp = newItem
  511. }
  512. }
  513. xDataList = append(xDataList, tmp)
  514. }
  515. dataListResp.XDataList = xDataList
  516. // todo 处理纵轴, 如果只存在一个右轴会有问题
  517. unitList := new(data_manage.ChartSectionCombineUnit)
  518. if baseSeries.IsAxis == 1 { //左轴,右轴
  519. leftUnit = firstUnit
  520. } else if baseSeries.IsAxis == 2 {
  521. rightUnit = firstUnit
  522. } else {
  523. right2Unit = firstUnit
  524. }
  525. if leftUnit != nil {
  526. unitList.LeftName = leftUnit.Name
  527. unitList.LeftNameEn = leftUnit.NameEn
  528. }
  529. if rightUnit != nil {
  530. unitList.RightName = rightUnit.Name
  531. unitList.RightNameEn = rightUnit.NameEn
  532. }
  533. if right2Unit != nil {
  534. unitList.RightTwoName = right2Unit.Name
  535. unitList.RightTwoNameEn = right2Unit.NameEn
  536. }
  537. if extraConfig.UnitList.LeftName != "" {
  538. unitList.LeftName = extraConfig.UnitList.LeftName
  539. unitList.LeftNameEn = extraConfig.UnitList.LeftNameEn
  540. }
  541. if extraConfig.UnitList.RightName != "" {
  542. unitList.RightName = extraConfig.UnitList.RightName
  543. unitList.RightNameEn = extraConfig.UnitList.RightNameEn
  544. }
  545. if extraConfig.UnitList.RightTwoName != "" {
  546. unitList.RightTwoName = extraConfig.UnitList.RightTwoName
  547. unitList.RightTwoNameEn = extraConfig.UnitList.RightTwoNameEn
  548. }
  549. if chartInfo != nil && chartInfo.MinMaxSave == 1 {
  550. dataListResp.LeftMin = chartInfo.LeftMin
  551. dataListResp.LeftMax = chartInfo.LeftMax
  552. dataListResp.RightMin = chartInfo.RightMin
  553. dataListResp.RightMax = chartInfo.RightMax
  554. dataListResp.Right2Min = chartInfo.Right2Min
  555. dataListResp.Right2Max = chartInfo.Right2Max
  556. } else {
  557. dataListResp.LeftMin = strconv.FormatFloat(LeftMin, 'f', -1, 64)
  558. dataListResp.LeftMax = strconv.FormatFloat(LeftMax, 'f', -1, 64)
  559. dataListResp.RightMin = strconv.FormatFloat(RightMin, 'f', -1, 64)
  560. dataListResp.RightMax = strconv.FormatFloat(RightMax, 'f', -1, 64)
  561. dataListResp.Right2Min = strconv.FormatFloat(Right2Min, 'f', -1, 64)
  562. dataListResp.Right2Max = strconv.FormatFloat(Right2Max, 'f', -1, 64)
  563. }
  564. // 查询引用日期里的指标信息
  565. if len(dateConfEdbIds) > 0 {
  566. dateConfEdbList, e := data_manage.GetEdbInfoByIdList(dateConfEdbIds)
  567. if e != nil {
  568. err = fmt.Errorf("查询引用日期里的指标信息失败,错误信息:%s", e.Error())
  569. return
  570. }
  571. dateConfEdbMap := make(map[int]*data_manage.EdbInfo)
  572. for _, dateConfEdb := range dateConfEdbList {
  573. dateConfEdbMap[dateConfEdb.EdbInfoId] = dateConfEdb
  574. }
  575. for i, dateConf := range extraConfig.DateConfList {
  576. if dateConf.EdbInfoId > 0 {
  577. edbItem, ok := dateConfEdbMap[dateConf.EdbInfoId]
  578. if ok {
  579. extraConfig.DateConfList[i].EdbName = edbItem.EdbName
  580. extraConfig.DateConfList[i].EdbInfoId = edbItem.EdbInfoId
  581. extraConfig.DateConfList[i].EdbInfoType = edbItem.EdbInfoType
  582. extraConfig.DateConfList[i].Frequency = edbItem.Frequency
  583. extraConfig.DateConfList[i].EndDate = edbItem.EndDate
  584. }
  585. }
  586. }
  587. }
  588. dataListResp.SeriesList = extraConfig.SeriesList
  589. dataListResp.DateConfList = extraConfig.DateConfList
  590. dataListResp.BaseChartSeriesName = extraConfig.BaseChartSeriesName
  591. dataListResp.UnitList = unitList
  592. dataListResp.IsHeap = extraConfig.IsHeap
  593. dataListResp.SortType = extraConfig.SortType
  594. return
  595. }
  596. // GetChartSectionSeriesDateByDateChange 获取日期变换后的日期edbInfoId 1指标日期,2 系统日期
  597. func GetChartSectionSeriesDateByDateChange(edbInfoId int, dataList []*data_manage.EdbDataList, dateChange []*data_manage.ChartSectionDateChange, moveForward int) (newDate string, err error) {
  598. if edbInfoId > 0 { //指标日期
  599. newDate = GetEdbDateByMoveForward(moveForward, dataList)
  600. } else {
  601. //系统日期
  602. newDate = time.Now().Format(utils.FormatDate)
  603. }
  604. if newDate != "" && len(dateChange) > 0 {
  605. newDate, err = HandleChartSectionSeriesDateChange(newDate, dateChange)
  606. }
  607. return
  608. }
  609. func GetEdbDateByMoveForward(moveForward int, edbDataList []*data_manage.EdbDataList) (date string) {
  610. dateList := make([]string, 0)
  611. for _, v := range edbDataList {
  612. dateList = append(dateList, v.DataTime)
  613. }
  614. date = GetEdbDateByMoveForwardByDateList(moveForward, dateList)
  615. return
  616. }
  617. func GetEdbDateByMoveForwardByDateList(moveForward int, dateList []string) (date string) {
  618. // 根据日期进行排序
  619. index := len(dateList) - 1 - moveForward
  620. for k, v := range dateList {
  621. if k == index {
  622. date = v
  623. return
  624. }
  625. }
  626. return
  627. }
  628. // HandleChartSectionSeriesDateChange 处理日期变换
  629. func HandleChartSectionSeriesDateChange(date string, dateChange []*data_manage.ChartSectionDateChange) (newDate string, err error) {
  630. newDate = date
  631. if newDate != "" {
  632. if len(dateChange) > 0 {
  633. var dateTime time.Time
  634. dateTime, err = time.ParseInLocation(utils.FormatDate, newDate, time.Local)
  635. if err != nil {
  636. err = fmt.Errorf("日期解析失败: %s", err.Error())
  637. return
  638. }
  639. for _, v := range dateChange {
  640. if v.ChangeType == 1 {
  641. dateTime = dateTime.AddDate(v.Year, v.Month, v.Day)
  642. newDate = dateTime.Format(utils.FormatDate)
  643. } else if v.ChangeType == 2 {
  644. newDate, err, _ = handleSystemAppointDateT(dateTime, v.FrequencyDay, v.Frequency)
  645. if err != nil {
  646. return
  647. }
  648. dateTime, err = time.ParseInLocation(utils.FormatDate, newDate, time.Local)
  649. if err != nil {
  650. err = fmt.Errorf("日期解析失败: %s", err.Error())
  651. return
  652. }
  653. }
  654. }
  655. }
  656. }
  657. return
  658. }
  659. // handleSystemAppointDateT
  660. // @Description: 处理系统日期相关的指定频率(所在周/旬/月/季/半年/年的最后/最早一天)
  661. // @author: Roc
  662. // @datetime2023-10-27 09:31:35
  663. // @param Frequency string
  664. // @param Day string
  665. // @return date string
  666. // @return err error
  667. // @return errMsg string
  668. func handleSystemAppointDateT(currDate time.Time, appointDay, frequency string) (date string, err error, errMsg string) {
  669. //currDate := time.Now()
  670. switch frequency {
  671. case "本周":
  672. day := int(currDate.Weekday())
  673. if day == 0 { // 周日
  674. day = 7
  675. }
  676. num := 0
  677. switch appointDay {
  678. case "周一":
  679. num = 1
  680. case "周二":
  681. num = 2
  682. case "周三":
  683. num = 3
  684. case "周四":
  685. num = 4
  686. case "周五":
  687. num = 5
  688. case "周六":
  689. num = 6
  690. case "周日":
  691. num = 7
  692. }
  693. day = num - day
  694. date = currDate.AddDate(0, 0, day).Format(utils.FormatDate)
  695. case "本旬":
  696. day := currDate.Day()
  697. var tmpDate time.Time
  698. switch appointDay {
  699. case "第一天":
  700. if day <= 10 {
  701. tmpDate = time.Date(currDate.Year(), currDate.Month(), 1, 0, 0, 0, 0, currDate.Location())
  702. } else if day <= 20 {
  703. tmpDate = time.Date(currDate.Year(), currDate.Month(), 11, 0, 0, 0, 0, currDate.Location())
  704. } else {
  705. tmpDate = time.Date(currDate.Year(), currDate.Month(), 21, 0, 0, 0, 0, currDate.Location())
  706. }
  707. case "最后一天":
  708. if day <= 10 {
  709. tmpDate = time.Date(currDate.Year(), currDate.Month(), 10, 0, 0, 0, 0, currDate.Location())
  710. } else if day <= 20 {
  711. tmpDate = time.Date(currDate.Year(), currDate.Month(), 20, 0, 0, 0, 0, currDate.Location())
  712. } else {
  713. tmpDate = time.Date(currDate.Year(), currDate.Month()+1, 1, 0, 0, 0, 0, currDate.Location()).AddDate(0, 0, -1)
  714. }
  715. }
  716. date = tmpDate.Format(utils.FormatDate)
  717. case "本月":
  718. var tmpDate time.Time
  719. switch appointDay {
  720. case "第一天":
  721. tmpDate = time.Date(currDate.Year(), currDate.Month(), 1, 0, 0, 0, 0, currDate.Location())
  722. case "最后一天":
  723. tmpDate = time.Date(currDate.Year(), currDate.Month()+1, 1, 0, 0, 0, 0, currDate.Location()).AddDate(0, 0, -1)
  724. }
  725. date = tmpDate.Format(utils.FormatDate)
  726. case "本季":
  727. month := currDate.Month()
  728. var tmpDate time.Time
  729. switch appointDay {
  730. case "第一天":
  731. if month <= 3 {
  732. tmpDate = time.Date(currDate.Year(), 1, 1, 0, 0, 0, 0, currDate.Location())
  733. } else if month <= 6 {
  734. tmpDate = time.Date(currDate.Year(), 4, 1, 0, 0, 0, 0, currDate.Location())
  735. } else if month <= 9 {
  736. tmpDate = time.Date(currDate.Year(), 7, 1, 0, 0, 0, 0, currDate.Location())
  737. } else {
  738. tmpDate = time.Date(currDate.Year(), 10, 1, 0, 0, 0, 0, currDate.Location())
  739. }
  740. case "最后一天":
  741. if month <= 3 {
  742. tmpDate = time.Date(currDate.Year(), 3, 31, 0, 0, 0, 0, currDate.Location())
  743. } else if month <= 6 {
  744. tmpDate = time.Date(currDate.Year(), 6, 30, 0, 0, 0, 0, currDate.Location())
  745. } else if month <= 9 {
  746. tmpDate = time.Date(currDate.Year(), 9, 30, 0, 0, 0, 0, currDate.Location())
  747. } else {
  748. tmpDate = time.Date(currDate.Year(), 12, 31, 0, 0, 0, 0, currDate.Location())
  749. }
  750. }
  751. date = tmpDate.Format(utils.FormatDate)
  752. case "本半年":
  753. month := currDate.Month()
  754. var tmpDate time.Time
  755. switch appointDay {
  756. case "第一天":
  757. if month <= 6 {
  758. tmpDate = time.Date(currDate.Year(), 1, 1, 0, 0, 0, 0, currDate.Location())
  759. } else {
  760. tmpDate = time.Date(currDate.Year(), 7, 1, 0, 0, 0, 0, currDate.Location())
  761. }
  762. case "最后一天":
  763. if month <= 6 {
  764. tmpDate = time.Date(currDate.Year(), 6, 30, 0, 0, 0, 0, currDate.Location())
  765. } else {
  766. tmpDate = time.Date(currDate.Year(), 12, 31, 0, 0, 0, 0, currDate.Location())
  767. }
  768. }
  769. date = tmpDate.Format(utils.FormatDate)
  770. case "本年":
  771. var tmpDate time.Time
  772. switch appointDay {
  773. case "第一天":
  774. tmpDate = time.Date(currDate.Year(), 1, 1, 0, 0, 0, 0, currDate.Location())
  775. case "最后一天":
  776. tmpDate = time.Date(currDate.Year(), 12, 31, 0, 0, 0, 0, currDate.Location())
  777. }
  778. date = tmpDate.Format(utils.FormatDate)
  779. default:
  780. errMsg = "错误的日期频度:" + frequency
  781. err = errors.New(errMsg)
  782. return
  783. }
  784. return
  785. }