chart_info_show.go 77 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478
  1. package services
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "eta/eta_forum_hub/models"
  6. "eta/eta_forum_hub/models/data"
  7. "eta/eta_forum_hub/utils"
  8. "fmt"
  9. "github.com/shopspring/decimal"
  10. "math"
  11. "sort"
  12. "strconv"
  13. "strings"
  14. "time"
  15. )
  16. type ChartInfoReq struct {
  17. ChartInfoId int `description:"图表id,新增时传0"`
  18. }
  19. // DeleteChartInfoDataRedis 清除图表缓存
  20. func DeleteChartInfoDataRedis(bodyByte []byte) (err error) {
  21. var req ChartInfoReq
  22. err = json.Unmarshal(bodyByte, &req)
  23. if err != nil {
  24. return
  25. }
  26. if req.ChartInfoId > 0 {
  27. err = utils.Rc.Delete(GetChartInfoDataKey(req.ChartInfoId))
  28. }
  29. return
  30. }
  31. // GetChartInfoDataKey 获取图表缓存的key
  32. func GetChartInfoDataKey(chartInfoId int) string {
  33. key := fmt.Sprint(utils.CACHE_CHART_INFO_DATA, chartInfoId)
  34. return key
  35. }
  36. // GetChartEdbData 获取图表的指标数据
  37. // GetChartEdbData 获取图表的指标数据
  38. func GetChartEdbData(chartInfoId, chartType int, calendar, startDate, endDate string, mappingList []*models.ChartEdbInfoMapping, extraConfigStr string, seasonExtraConfig string) (edbList []*models.ChartEdbInfoMapping, xEdbIdValue []int, yDataList []models.YData, dataResp interface{}, err error, errMsg string) {
  39. edbList = make([]*models.ChartEdbInfoMapping, 0)
  40. xEdbIdValue = make([]int, 0)
  41. yDataList = make([]models.YData, 0)
  42. var extraConfig interface{}
  43. switch chartType {
  44. case 6:
  45. var tmpConfig models.ChartTimeCombineExtraConf
  46. if extraConfigStr != `` {
  47. err = json.Unmarshal([]byte(extraConfigStr), &tmpConfig)
  48. if err != nil {
  49. errMsg = "雷达图配置异常"
  50. err = errors.New(errMsg)
  51. return
  52. }
  53. }
  54. extraConfig = tmpConfig
  55. case 7: // 柱形图
  56. var barConfig models.BarChartInfoReq
  57. if extraConfigStr == `` {
  58. errMsg = "柱方图未配置"
  59. err = errors.New(errMsg)
  60. return
  61. }
  62. err = json.Unmarshal([]byte(extraConfigStr), &barConfig)
  63. if err != nil {
  64. errMsg = "柱方图配置异常"
  65. err = errors.New(errMsg)
  66. return
  67. }
  68. extraConfig = barConfig
  69. case 10: // 截面散点图
  70. var tmpExtraConfig models.SectionScatterReq
  71. if extraConfigStr == `` {
  72. errMsg = "截面散点图未配置"
  73. err = errors.New(errMsg)
  74. return
  75. }
  76. err = json.Unmarshal([]byte(extraConfigStr), &tmpExtraConfig)
  77. if err != nil {
  78. errMsg = "截面散点配置异常"
  79. err = errors.New(errMsg)
  80. return
  81. }
  82. extraConfig = tmpExtraConfig
  83. case utils.CHART_TYPE_RADAR:
  84. var barConfig models.RadarChartInfoReq
  85. if extraConfigStr == `` {
  86. errMsg = "雷达图未配置"
  87. err = errors.New(errMsg)
  88. return
  89. }
  90. err = json.Unmarshal([]byte(extraConfigStr), &barConfig)
  91. if err != nil {
  92. errMsg = "雷达图配置异常"
  93. err = errors.New(errMsg)
  94. return
  95. }
  96. extraConfig = barConfig
  97. case utils.CHART_TYPE_SECTION_COMBINE:
  98. // 预览和详情都走这个接口
  99. var sectionExtraConfig models.ChartSectionAllExtraConf
  100. if extraConfigStr == `` {
  101. errMsg = "截面组合图未配置"
  102. err = errors.New(errMsg)
  103. return
  104. }
  105. if chartInfoId > 0 {
  106. var sectionExtraConfigTmp models.ChartSectionExtraConf
  107. err = json.Unmarshal([]byte(extraConfigStr), &sectionExtraConfigTmp)
  108. if err != nil {
  109. errMsg = "截面组合图配置异常"
  110. err = errors.New(errMsg)
  111. return
  112. }
  113. sectionExtraConfig.XDataList = sectionExtraConfigTmp.XDataList
  114. sectionExtraConfig.BaseChartSeriesName = sectionExtraConfigTmp.BaseChartSeriesName
  115. sectionExtraConfig.UnitList = sectionExtraConfigTmp.UnitList
  116. sectionExtraConfig.DateConfList = sectionExtraConfigTmp.DateConfList
  117. sectionExtraConfig.IsHeap = sectionExtraConfigTmp.IsHeap
  118. sectionExtraConfig.SortType = sectionExtraConfigTmp.SortType
  119. // 查询所有的seriesEdb
  120. seriesEdbList, e := models.GetChartSeriesEdbByChartInfoId(chartInfoId)
  121. if e != nil {
  122. errMsg = "查询seriesEdb失败"
  123. err = errors.New(errMsg + e.Error())
  124. return
  125. }
  126. // todo 是否有必要返回单位信息
  127. // 组装成map
  128. seriesEdbMap := make(map[int][]*models.ChartSectionSeriesEdbConf)
  129. for _, v := range seriesEdbList {
  130. var dateConf *models.ChartSectionSeriesDateConfItem
  131. if v.DateConf != "" {
  132. err = json.Unmarshal([]byte(v.DateConf), &dateConf)
  133. if err != nil {
  134. errMsg = "截面组合图配置异常"
  135. err = errors.New(errMsg + err.Error())
  136. return
  137. }
  138. }
  139. tmp := &models.ChartSectionSeriesEdbConf{
  140. ChartSeriesEdbMappingId: v.ChartSeriesEdbMappingId,
  141. ChartSeriesId: v.ChartSeriesId,
  142. //ChartInfoId: v.ChartInfoId,
  143. EdbInfoId: v.EdbInfoId,
  144. DateConf: dateConf,
  145. EdbName: "",
  146. EdbNameEn: "",
  147. Unit: "",
  148. UnitEn: "",
  149. DateConfName: v.DateConfName,
  150. DateConfType: v.DateConfType,
  151. }
  152. seriesEdbMap[v.ChartSeriesId] = append(seriesEdbMap[v.ChartSeriesId], tmp)
  153. }
  154. //查询series
  155. seriesListTmp, e := models.GetChartSeriesByChartInfoId(chartInfoId)
  156. if e != nil {
  157. errMsg = "查询series失败"
  158. err = errors.New(errMsg + e.Error())
  159. return
  160. }
  161. seriesList := make([]*models.ChartSectionSeriesItem, 0)
  162. for _, v := range seriesListTmp {
  163. tmpSeries := &models.ChartSectionSeriesItem{
  164. ChartSeriesId: v.ChartSeriesId,
  165. SeriesName: v.SeriesName,
  166. SeriesNameEn: v.SeriesNameEn,
  167. ChartStyle: v.ChartStyle,
  168. ChartColor: v.ChartColor,
  169. ChartWidth: v.ChartWidth,
  170. IsPoint: v.IsPoint,
  171. IsNumber: v.IsNumber,
  172. IsAxis: v.IsAxis,
  173. MaxData: v.MaxData,
  174. MinData: v.MinData,
  175. //IsOrder: false,
  176. EdbInfoList: nil,
  177. DataList: nil,
  178. }
  179. edbInfoList, ok := seriesEdbMap[v.ChartSeriesId]
  180. if ok {
  181. tmpSeries.EdbInfoList = edbInfoList
  182. }
  183. seriesList = append(seriesList, tmpSeries)
  184. }
  185. sectionExtraConfig.SeriesList = seriesList
  186. } else {
  187. err = json.Unmarshal([]byte(extraConfigStr), &sectionExtraConfig)
  188. if err != nil {
  189. errMsg = "截面组合图配置异常"
  190. err = errors.New(errMsg)
  191. return
  192. }
  193. }
  194. //校验引用日期名称是否重复
  195. dateNameMap := make(map[string]int)
  196. dateNameEnMap := make(map[string]int)
  197. for _, v := range sectionExtraConfig.DateConfList {
  198. if _, ok := dateNameMap[v.DateConfName]; ok {
  199. errMsg = "截面组合图引用日期名称设置重复"
  200. err = errors.New(errMsg + v.DateConfName)
  201. return
  202. }
  203. if _, ok := dateNameEnMap[v.DateConfNameEn]; ok {
  204. errMsg = "截面组合图引用日期名称设置重复"
  205. err = errors.New(errMsg + v.DateConfNameEn)
  206. return
  207. }
  208. if v.DateConfName != "" {
  209. dateNameMap[v.DateConfName] = 1
  210. }
  211. if v.DateConfNameEn != "" {
  212. dateNameEnMap[v.DateConfNameEn] = 1
  213. }
  214. }
  215. //检查系列名称是否重复
  216. seriesNameMap := make(map[string]int)
  217. seriesNameEnMap := make(map[string]int)
  218. for _, v := range sectionExtraConfig.SeriesList {
  219. if _, ok := seriesNameMap[v.SeriesName]; ok {
  220. errMsg = "截面组合图系列名称设置重复"
  221. err = errors.New(errMsg + v.SeriesName)
  222. return
  223. }
  224. if _, ok := seriesNameEnMap[v.SeriesNameEn]; ok {
  225. errMsg = "截面组合图系列名称设置重复"
  226. err = errors.New(errMsg + v.SeriesNameEn)
  227. return
  228. }
  229. if v.SeriesName != "" {
  230. seriesNameMap[v.SeriesName] = 1
  231. }
  232. if v.SeriesNameEn != "" {
  233. seriesNameEnMap[v.SeriesNameEn] = 1
  234. }
  235. }
  236. // 检查基准系列是否设置
  237. if sectionExtraConfig.BaseChartSeriesName == "" {
  238. errMsg = "截面组合图基准系列名称未设置"
  239. err = errors.New(errMsg)
  240. return
  241. }
  242. //todo 如果是详情接口,应该要从其他表里查询配置
  243. extraConfig = sectionExtraConfig
  244. default:
  245. xEdbIdValue = make([]int, 0)
  246. yDataList = make([]models.YData, 0)
  247. }
  248. // 指标对应的所有数据
  249. edbDataListMap, edbList, err := getEdbDataMapList(chartInfoId, chartType, calendar, startDate, endDate, mappingList, seasonExtraConfig)
  250. if err != nil {
  251. return
  252. }
  253. // 特殊图形数据处理
  254. switch chartType {
  255. case 2: // 季节性图
  256. if seasonExtraConfig != "" {
  257. // 季节性图计算不管图上数据时间,拿所有数据
  258. _, tempEdbList, e := getEdbDataMapList(chartInfoId, chartType, calendar, "1990-01-01", "", mappingList, seasonExtraConfig)
  259. if e != nil {
  260. err = e
  261. return
  262. }
  263. dataResp, err = SeasonChartData(tempEdbList, seasonExtraConfig)
  264. } else {
  265. // 兼容无配置的老图
  266. dataResp = new(models.SeasonChartResp)
  267. }
  268. case 6: //时序组合图
  269. //判断是否堆积
  270. timeConf := extraConfig.(models.ChartTimeCombineExtraConf)
  271. if extraConfigStr == "" { //历史数据,默认开启堆积
  272. timeConf = models.ChartTimeCombineExtraConf{
  273. IsHeap: 1,
  274. }
  275. }
  276. dataResp = models.ChartTimeCombineDataResp{IsHeap: timeConf.IsHeap}
  277. case 7: // 柱形图
  278. barChartConf := extraConfig.(models.BarChartInfoReq)
  279. xEdbIdValue, yDataList, err = BarChartData(mappingList, edbDataListMap, barChartConf.DateList, barChartConf.Sort)
  280. for k := range yDataList {
  281. yDataList[k].Unit = barChartConf.Unit
  282. yDataList[k].UnitEn = barChartConf.UnitEn
  283. }
  284. for _, v := range edbList {
  285. // 指标别名
  286. if barChartConf.EdbInfoIdList != nil && len(barChartConf.EdbInfoIdList) > 0 {
  287. for _, reqEdb := range barChartConf.EdbInfoIdList {
  288. if v.EdbInfoId == reqEdb.EdbInfoId {
  289. v.EdbAliasName = reqEdb.Name
  290. }
  291. }
  292. }
  293. }
  294. case 10: // 截面散点图
  295. sectionScatterConf := extraConfig.(models.SectionScatterReq)
  296. xEdbIdValue, dataResp, err = GetSectionScatterChartData(chartInfoId, mappingList, edbDataListMap, sectionScatterConf)
  297. var tmpExtraConfig models.SectionScatterReq
  298. if extraConfigStr == `` {
  299. errMsg = "截面散点图未配置"
  300. err = errors.New(errMsg)
  301. return
  302. }
  303. err = json.Unmarshal([]byte(extraConfigStr), &tmpExtraConfig)
  304. if err != nil {
  305. errMsg = "截面散点配置异常"
  306. err = errors.New(errMsg)
  307. return
  308. }
  309. // 这个数据没有必要返回给前端
  310. for _, v := range edbList {
  311. v.DataList = nil
  312. }
  313. case utils.CHART_TYPE_SECTION_COMBINE: // 截面组合图
  314. sectionConf := extraConfig.(models.ChartSectionAllExtraConf)
  315. var chartInfo *models.ChartInfo
  316. if chartInfoId > 0 {
  317. chartInfo, err = models.GetChartInfoById(chartInfoId)
  318. if err != nil {
  319. errMsg = "获取图表信息失败"
  320. return
  321. }
  322. }
  323. xEdbIdValue, dataResp, err = GetChartSectionCombineData(chartInfo, mappingList, edbDataListMap, sectionConf)
  324. // 这个数据没有必要返回给前端
  325. for _, v := range edbList {
  326. v.DataList = nil
  327. }
  328. case utils.CHART_TYPE_RADAR: //雷达图
  329. radarConf := extraConfig.(models.RadarChartInfoReq)
  330. xEdbIdValue, dataResp, err = RadarChartData(mappingList, edbDataListMap, radarConf)
  331. }
  332. return
  333. }
  334. // GetEdbDataMapList 获取指标最后的基础数据
  335. func GetEdbDataMapList(chartInfoId, chartType int, calendar, startDate, endDate string, mappingList []*models.ChartEdbInfoMapping, seasonExtra string) (edbDataListMap map[int][]*models.EdbDataList, edbList []*models.ChartEdbInfoMapping, err error) {
  336. edbDataListMap, edbList, err = getEdbDataMapList(chartInfoId, chartType, calendar, startDate, endDate, mappingList, seasonExtra)
  337. return
  338. }
  339. // getEdbDataMapList 获取指标最后的基础数据
  340. func getEdbDataMapList(chartInfoId, chartType int, calendar, startDate, endDate string, mappingList []*models.ChartEdbInfoMapping, seasonExtraConfig string) (edbDataListMap map[int][]*models.EdbDataList, edbList []*models.ChartEdbInfoMapping, err error) {
  341. // 指标对应的所有数据
  342. edbDataListMap = make(map[int][]*models.EdbDataList)
  343. for _, v := range mappingList {
  344. //fmt.Println("v:", v.EdbInfoId)
  345. item := new(models.ChartEdbInfoMapping)
  346. item.EdbInfoId = v.EdbInfoId
  347. item.SourceName = v.SourceName
  348. item.Source = v.Source
  349. item.EdbCode = v.EdbCode
  350. item.EdbName = v.EdbName
  351. item.EdbNameEn = v.EdbNameEn
  352. item.Frequency = v.Frequency
  353. item.EdbType = v.EdbType
  354. item.FrequencyEn = GetFrequencyEn(v.Frequency)
  355. if v.Unit != `无` {
  356. item.Unit = v.Unit
  357. }
  358. item.UnitEn = v.UnitEn
  359. item.StartDate = v.StartDate
  360. item.EndDate = v.EndDate
  361. item.ModifyTime = v.ModifyTime
  362. item.EdbInfoCategoryType = v.EdbInfoCategoryType
  363. item.PredictChartColor = v.PredictChartColor
  364. item.ClassifyId = v.ClassifyId
  365. if chartInfoId <= 0 {
  366. item.IsAxis = 1
  367. item.LeadValue = 0
  368. item.LeadUnit = ""
  369. item.ChartEdbMappingId = 0
  370. item.ChartInfoId = 0
  371. item.IsOrder = false
  372. item.EdbInfoType = 1
  373. item.ChartStyle = ""
  374. item.ChartColor = ""
  375. item.ChartWidth = 0
  376. item.MaxData = v.MaxValue
  377. item.MinData = v.MinValue
  378. } else {
  379. item.IsAxis = v.IsAxis
  380. item.EdbInfoType = v.EdbInfoType
  381. item.LeadValue = v.LeadValue
  382. item.LeadUnit = v.LeadUnit
  383. item.LeadUnitEn = GetLeadUnitEn(v.LeadUnit)
  384. item.ChartEdbMappingId = v.ChartEdbMappingId
  385. item.ChartInfoId = v.ChartInfoId
  386. item.ChartStyle = v.ChartStyle
  387. item.ChartColor = v.ChartColor
  388. item.ChartWidth = v.ChartWidth
  389. item.IsOrder = v.IsOrder
  390. item.MaxData = v.MaxData
  391. item.MinData = v.MinData
  392. }
  393. item.LatestValue = v.LatestValue
  394. item.LatestDate = v.LatestDate
  395. item.UniqueCode = v.UniqueCode
  396. item.MoveLatestDate = v.LatestDate
  397. item.EdbAliasName = v.EdbAliasName
  398. item.IsConvert = v.IsConvert
  399. item.ConvertType = v.ConvertType
  400. item.ConvertValue = v.ConvertValue
  401. item.ConvertUnit = v.ConvertUnit
  402. item.ConvertEnUnit = v.ConvertEnUnit
  403. item.IsJoinPermission = v.IsJoinPermission
  404. var startDateReal string
  405. var diffSeconds int64
  406. if chartType == 2 { //季节性图
  407. startDateReal = startDate
  408. if len(mappingList) > 1 {
  409. item.IsAxis = v.IsAxis
  410. }
  411. } else {
  412. if v.EdbInfoType == 0 && v.LeadUnit != "" && v.LeadValue > 0 { //领先指标
  413. var startTimeRealTemp time.Time
  414. startDateParse, _ := time.Parse(utils.FormatDate, startDate)
  415. switch v.LeadUnit {
  416. case "天":
  417. startTimeRealTemp = startDateParse.AddDate(0, 0, -v.LeadValue)
  418. case "月":
  419. startTimeRealTemp = startDateParse.AddDate(0, -v.LeadValue, 0)
  420. case "季":
  421. startTimeRealTemp = startDateParse.AddDate(0, -3*v.LeadValue, 0)
  422. case "周":
  423. startTimeRealTemp = startDateParse.AddDate(0, 0, -7*v.LeadValue)
  424. case "年":
  425. startTimeRealTemp = startDateParse.AddDate(-v.LeadValue, 0, 0)
  426. }
  427. if startTimeRealTemp.Before(startDateParse) {
  428. startDateReal = startTimeRealTemp.Format(utils.FormatDate)
  429. diffSeconds = (int64(startTimeRealTemp.UnixNano()) - int64(startDateParse.UnixNano())) / 1e6
  430. } else {
  431. startDateReal = startDate
  432. diffSeconds = 0
  433. }
  434. // todo 预测指标的开始日期也要偏移
  435. /*{
  436. day, tmpErr := utils.GetDaysBetween2Date(utils.FormatDate, startDate, startDateReal)
  437. if tmpErr != nil {
  438. err = tmpErr
  439. return
  440. }
  441. moveLatestDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, item.MoveLatestDate, time.Local)
  442. if tmpErr != nil {
  443. err = tmpErr
  444. return
  445. }
  446. item.MoveLatestDate = moveLatestDateTime.AddDate(0, 0, day).Format(utils.FormatDate)
  447. }*/
  448. } else {
  449. startDateReal = startDate
  450. }
  451. }
  452. //fmt.Println("line 1011 chart:", v.Source, v.EdbInfoId, startDateReal, endDate)
  453. calendarPreYear := 0
  454. if calendar == "农历" {
  455. newStartDateReal, err := time.Parse(utils.FormatDate, startDateReal)
  456. if err != nil {
  457. fmt.Println("time.Parse:" + err.Error())
  458. }
  459. calendarPreYear = newStartDateReal.Year() - 1
  460. newStartDateReal = newStartDateReal.AddDate(-1, 0, 0)
  461. startDateReal = newStartDateReal.Format(utils.FormatDate)
  462. }
  463. dataList := make([]*models.EdbDataList, 0)
  464. dataList, err = GetEdbDataList(v.EdbInfoId, v.EdbType, startDateReal, endDate)
  465. if err != nil {
  466. // 获取指标数据失败
  467. err = fmt.Errorf("获取指标数据失败 GetEdbDataList error, %v", err)
  468. return
  469. }
  470. if v.IsConvert == 1 {
  471. switch v.ConvertType {
  472. case 1:
  473. for i, data := range dataList {
  474. dataList[i].Value = data.Value * v.ConvertValue
  475. }
  476. //item.MaxData = item.MaxData * v.ConvertValue
  477. //item.MinData = item.MinData * v.ConvertValue
  478. case 2:
  479. for i, data := range dataList {
  480. dataList[i].Value = data.Value / v.ConvertValue
  481. }
  482. //item.MaxData = item.MaxData / v.ConvertValue
  483. //item.MinData = item.MinData / v.ConvertValue
  484. case 3:
  485. for i, data := range dataList {
  486. if data.Value <= 0 {
  487. err = errors.New("数据中含有负数或0,无法对数运算")
  488. return
  489. }
  490. dataList[i].Value = math.Log(data.Value) / math.Log(v.ConvertValue)
  491. }
  492. //item.MaxData = math.Log(item.MaxData) / math.Log(v.ConvertValue)
  493. //item.MinData = math.Log(item.MinData) / math.Log(v.ConvertValue)
  494. }
  495. }
  496. edbDataListMap[v.EdbInfoId] = dataList
  497. if diffSeconds != 0 && v.EdbInfoType == 0 {
  498. dataListLen := len(dataList)
  499. for i := 0; i < dataListLen; i++ {
  500. dataList[i].DataTimestamp = dataList[i].DataTimestamp - diffSeconds
  501. }
  502. }
  503. if chartType == 2 && item.IsAxis == 1 {
  504. latestDate, tmpErr := time.Parse(utils.FormatDate, v.LatestDate)
  505. if tmpErr != nil {
  506. //item.DataList = dataList
  507. item.IsNullData = true
  508. edbList = append(edbList, item)
  509. continue
  510. err = errors.New(fmt.Sprint("获取最后实际数据的日期失败,Err:" + tmpErr.Error() + ";LatestDate:" + v.LatestDate))
  511. return
  512. }
  513. if calendar == "农历" {
  514. if len(dataList) <= 0 {
  515. result := new(data.EdbDataResult)
  516. item.DataList = result
  517. } else {
  518. result, tmpErr := data.AddCalculateQuarterV6(dataList)
  519. if tmpErr != nil {
  520. err = errors.New("获取农历数据失败,Err:" + tmpErr.Error())
  521. return
  522. }
  523. quarterDataList, tErr := GetSeasonEdbInfoDataListByXDateNong(result, latestDate, seasonExtraConfig, calendarPreYear)
  524. if tErr != nil {
  525. err = errors.New("获取季节性图表数据失败,Err:" + tErr.Error())
  526. return
  527. }
  528. item.DataList = quarterDataList
  529. }
  530. } else {
  531. quarterDataList, tErr := GetSeasonEdbInfoDataListByXDate(dataList, latestDate, seasonExtraConfig)
  532. if tErr != nil {
  533. err = errors.New("获取季节性图表数据失败,Err:" + tErr.Error())
  534. return
  535. }
  536. item.DataList = quarterDataList
  537. }
  538. } else if chartType == 2 && item.IsAxis == 0 {
  539. // 右轴数据处理,只要最新一年
  540. latestDate, tmpErr := time.Parse(utils.FormatDate, v.LatestDate)
  541. if tmpErr != nil {
  542. //item.DataList = dataList
  543. item.IsNullData = true
  544. edbList = append(edbList, item)
  545. continue
  546. err = errors.New(fmt.Sprint("获取最后实际数据的日期失败,Err:" + tmpErr.Error() + ";LatestDate:" + v.LatestDate))
  547. return
  548. }
  549. newDataList := make([]*models.EdbDataList, 0)
  550. for _, v := range dataList {
  551. dataTime, e := time.Parse(utils.FormatDate, v.DataTime)
  552. if e != nil {
  553. err = errors.New("季节性图处理右轴指标数据转换日期失败,Err:" + e.Error())
  554. return
  555. }
  556. if dataTime.Year() == latestDate.Year() {
  557. newDataList = append(newDataList, v)
  558. }
  559. }
  560. item.DataList = newDataList
  561. } else if chartType == 7 || chartType == utils.CHART_TYPE_RADAR { //柱方图
  562. //item.DataList = dataList
  563. } else {
  564. item.DataList = dataList
  565. }
  566. edbList = append(edbList, item)
  567. }
  568. return
  569. }
  570. // GetSeasonEdbInfoDataListByXDate 季节性图的指标数据根据横轴展示
  571. func GetSeasonEdbInfoDataListByXDate(dataList []*models.EdbDataList, latestDate time.Time, seasonExtraConfig string) (quarterDataListSort models.QuarterDataList, err error) {
  572. xStartDate := "01-01"
  573. xEndDate := "12-31"
  574. jumpYear := 0
  575. legends := make([]models.SeasonChartLegend, 0)
  576. var seasonExtra models.SeasonExtraItem
  577. if seasonExtraConfig != "" {
  578. err = json.Unmarshal([]byte(seasonExtraConfig), &seasonExtra)
  579. if err != nil {
  580. return
  581. }
  582. }
  583. if seasonExtra.XStartDate != "" {
  584. xStartDate = seasonExtra.XStartDate
  585. xEndDate = seasonExtra.XEndDate
  586. jumpYear = seasonExtra.JumpYear
  587. legends = seasonExtra.ChartLegend
  588. }
  589. length := len(dataList)
  590. if length == 0 {
  591. return
  592. }
  593. legendMap := make(map[string]string, 0)
  594. if len(legends) > 0 {
  595. for _, v := range legends {
  596. legendMap[v.Name] = v.Value
  597. }
  598. }
  599. latestDateStr := latestDate.Format(utils.FormatDate)
  600. //判断横轴的两个时间之间是不是跨年了,如果跨年了,则横轴截止年份比起始年份+1,如果不跨年,截止年份等于起始年份
  601. //根据数据确定最早的年份,和最近年份
  602. //根据横轴的日期,汇总所有的年份
  603. startDate := dataList[0].DataTime
  604. startDateT, tmpErr := time.Parse(utils.FormatDate, startDate)
  605. if tmpErr != nil {
  606. err = tmpErr
  607. return
  608. }
  609. startYear := startDateT.Year()
  610. //获取数据的最新日期
  611. lastDate := dataList[length-1].DataTime
  612. lastDateT, tmpErr := time.Parse(utils.FormatDate, lastDate)
  613. if tmpErr != nil {
  614. err = tmpErr
  615. return
  616. }
  617. endYear := lastDateT.Year()
  618. nowYear := time.Now().Year()
  619. dataMap := make(map[string]models.QuarterXDateItem, 0)
  620. quarterDataList := make([]*models.QuarterData, 0)
  621. quarterMap := make(map[string][]*models.EdbDataList, 0)
  622. //整理出日期
  623. idx := 1
  624. chartLegendMap := make(map[string]int, 0)
  625. for currentStartYear := startYear; currentStartYear <= endYear; currentStartYear++ {
  626. startStr := fmt.Sprintf("%d-%s", currentStartYear, xStartDate)
  627. currentEndYear := currentStartYear
  628. if jumpYear == 1 {
  629. currentEndYear = currentStartYear + 1
  630. }
  631. endStr := fmt.Sprintf("%d-%s", currentEndYear, xEndDate)
  632. name := fmt.Sprintf("%s_%s", startStr, endStr)
  633. showName := fmt.Sprintf("%d_%d", currentStartYear, currentEndYear)
  634. startT, tEr := time.Parse(utils.FormatDate, startStr)
  635. if tEr != nil {
  636. err = tEr
  637. return
  638. }
  639. endT, tEr := time.Parse(utils.FormatDate, endStr)
  640. if tEr != nil {
  641. err = tEr
  642. return
  643. }
  644. if lastDateT.Before(startT) {
  645. //如果最新的日期在起始日之前,则跳出循环
  646. break
  647. }
  648. if endT.Year() > nowYear {
  649. //如果最新的日期比真实年份要大,则数据全部按照最大的年份补齐
  650. nowYear = endT.Year()
  651. }
  652. item := models.QuarterXDateItem{
  653. StartDate: startT,
  654. EndDate: endT,
  655. ShowName: showName,
  656. }
  657. dataMap[name] = item
  658. chartLegendMap[name] = idx
  659. idx++
  660. fmt.Println("年份" + showName + "日期" + startStr + " " + endStr)
  661. if lastDateT.Before(endT) {
  662. //如果最新的日期在起始日之前,则跳出循环
  663. break
  664. }
  665. }
  666. lenYear := len(dataMap)
  667. for k, v := range dataMap {
  668. if i, ok := chartLegendMap[k]; ok {
  669. v.ChartLegend = strconv.Itoa(endYear - lenYear + i)
  670. }
  671. dataMap[k] = v
  672. }
  673. for _, v := range dataList {
  674. dataTimeT, _ := time.Parse(utils.FormatDate, v.DataTime)
  675. year := dataTimeT.Year()
  676. newItemDate := dataTimeT.AddDate(nowYear-year, 0, 0)
  677. for k, dateItem := range dataMap {
  678. tmpVal := models.EdbDataList{
  679. EdbDataId: v.EdbDataId,
  680. EdbInfoId: v.EdbInfoId,
  681. DataTime: v.DataTime,
  682. DataTimestamp: v.DataTimestamp,
  683. Value: v.Value,
  684. }
  685. if (dateItem.StartDate.Before(dataTimeT) && dateItem.EndDate.After(dataTimeT)) || dateItem.StartDate == dataTimeT || dateItem.EndDate == dataTimeT {
  686. if jumpYear == 1 {
  687. //计算前一年最大的日期, 只补齐数据到去年
  688. beforeYearMaxDate := fmt.Sprintf("%d-12-31", dateItem.StartDate.Year())
  689. beforeYearMaxDateT, _ := time.Parse(utils.FormatDate, beforeYearMaxDate)
  690. if dataTimeT.Before(beforeYearMaxDateT) || dataTimeT == beforeYearMaxDateT {
  691. newItemDate = dataTimeT.AddDate(nowYear-year-1, 0, 0)
  692. } else {
  693. newItemDate = dataTimeT.AddDate(nowYear-year, 0, 0)
  694. }
  695. } else {
  696. newItemDate = dataTimeT.AddDate(nowYear-year, 0, 0)
  697. }
  698. timestamp := newItemDate.UnixNano() / 1e6
  699. tmpVal.DataTimestamp = timestamp
  700. tmpV := &tmpVal
  701. if findVal, ok := quarterMap[k]; !ok {
  702. findVal = append(findVal, tmpV)
  703. quarterMap[k] = findVal
  704. } else {
  705. findVal = append(findVal, tmpV)
  706. quarterMap[k] = findVal
  707. }
  708. if v.DataTime == latestDateStr {
  709. dateItem.CuttingDataTimestamp = timestamp
  710. dataMap[k] = dateItem
  711. }
  712. //break
  713. }
  714. }
  715. }
  716. for k, v := range dataMap {
  717. itemList := quarterMap[k]
  718. quarterItem := new(models.QuarterData)
  719. quarterItem.Years = v.ShowName
  720. quarterItem.ChartLegend = v.ChartLegend
  721. if le, ok := legendMap[v.ShowName]; ok {
  722. if le != strconv.Itoa(v.StartDate.Year()) && le != strconv.Itoa(v.EndDate.Year()) {
  723. quarterItem.ChartLegend = le
  724. }
  725. }
  726. quarterItem.DataList = itemList
  727. quarterItem.CuttingDataTimestamp = v.CuttingDataTimestamp
  728. //如果等于最后的实际日期,那么将切割时间戳记录
  729. if quarterItem.CuttingDataTimestamp == 0 {
  730. //如果大于最后的实际日期,那么第一个点就是切割的时间戳
  731. if latestDate.Before(v.StartDate) && len(itemList) > 0 {
  732. quarterItem.CuttingDataTimestamp = itemList[0].DataTimestamp - 100
  733. }
  734. }
  735. quarterDataList = append(quarterDataList, quarterItem)
  736. }
  737. if len(quarterDataList) > 0 {
  738. quarterDataListSort = quarterDataList
  739. sort.Sort(quarterDataListSort)
  740. }
  741. return
  742. }
  743. // GetSeasonEdbInfoDataListByXDateNong 季节性图的指标数据根据横轴选择农历时展示
  744. func GetSeasonEdbInfoDataListByXDateNong(result *data.EdbDataResult, latestDate time.Time, seasonExtraConfig string, calendarPreYear int) (quarterDataListSort models.QuarterDataList, err error) {
  745. xStartDate := "01-01"
  746. xEndDate := "12-31"
  747. jumpYear := 0
  748. legends := make([]models.SeasonChartLegend, 0)
  749. var seasonExtra models.SeasonExtraItem
  750. if seasonExtraConfig != "" {
  751. err = json.Unmarshal([]byte(seasonExtraConfig), &seasonExtra)
  752. if err != nil {
  753. return
  754. }
  755. }
  756. if seasonExtra.XStartDate != "" {
  757. xStartDate = seasonExtra.XStartDate
  758. xEndDate = seasonExtra.XEndDate
  759. jumpYear = seasonExtra.JumpYear
  760. legends = seasonExtra.ChartLegend
  761. }
  762. length := len(result.List)
  763. if length == 0 {
  764. return
  765. }
  766. legendMap := make(map[string]string, 0)
  767. if len(legends) > 0 {
  768. for _, v := range legends {
  769. legendMap[v.Name] = v.Value
  770. }
  771. }
  772. latestDateYear := latestDate.Year()
  773. //判断横轴的两个时间之间是不是跨年了,如果跨年了,则横轴截止年份比起始年份+1,如果不跨年,截止年份等于起始年份
  774. //根据数据确定最早的年份,和最近年份
  775. //根据横轴的日期,汇总所有的年份
  776. startYear := result.List[0].Year
  777. /*if jumpYear == 1 {
  778. if startYear != calendarPreYear {
  779. startYear = startYear - 1
  780. }
  781. }*/
  782. itemLength := len(result.List[length-1].Items)
  783. //获取数据的最新日期
  784. lastDate := result.List[length-1].Items[itemLength-1].DataTime
  785. maxY := result.List[length-1].Year
  786. lastDateT, tmpErr := time.Parse(utils.FormatDate, lastDate)
  787. if tmpErr != nil {
  788. err = tmpErr
  789. return
  790. }
  791. endYear := lastDateT.Year()
  792. nowYear := time.Now().Year()
  793. dataMap := make(map[string]models.QuarterXDateItem, 0)
  794. quarterDataList := make([]*models.QuarterData, 0)
  795. resultData := make([]*models.QuarterData, 0)
  796. quarterMap := make(map[string][]*models.EdbDataList, 0)
  797. //整理出日期
  798. var startTmpT, endTmpT time.Time
  799. idx := 1
  800. chartLegendMap := make(map[string]int, 0)
  801. for currentStartYear := startYear; currentStartYear <= endYear; currentStartYear++ {
  802. startStr := fmt.Sprintf("%d-%s", currentStartYear, xStartDate)
  803. currentEndYear := currentStartYear
  804. if jumpYear == 1 {
  805. currentEndYear = currentStartYear + 1
  806. }
  807. endStr := fmt.Sprintf("%d-%s", currentEndYear, xEndDate)
  808. showName := fmt.Sprintf("%d_%d", currentStartYear, currentEndYear)
  809. startT, tEr := time.Parse(utils.FormatDate, startStr)
  810. if tEr != nil {
  811. err = tEr
  812. return
  813. }
  814. endT, tEr := time.Parse(utils.FormatDate, endStr)
  815. if tEr != nil {
  816. err = tEr
  817. return
  818. }
  819. if lastDateT.Before(startT) {
  820. //如果最新的日期在起始日之前,则跳出循环
  821. break
  822. }
  823. if endT.Year() > nowYear {
  824. //如果最新的日期比真实年份要大,则数据全部按照最大的年份补齐
  825. nowYear = endT.Year()
  826. }
  827. item := models.QuarterXDateItem{
  828. StartDate: startT,
  829. EndDate: endT,
  830. ShowName: showName,
  831. }
  832. dataMap[showName] = item
  833. fmt.Println("年份" + showName + "日期" + startStr + " " + endStr)
  834. startTmpT = startT
  835. endTmpT = endT
  836. chartLegendMap[showName] = idx
  837. idx++
  838. if lastDateT.Before(endT) {
  839. //如果最新的日期在起始日之前,则跳出循环
  840. break
  841. }
  842. }
  843. lenYear := len(dataMap)
  844. for k, v := range dataMap {
  845. if i, ok := chartLegendMap[k]; ok {
  846. v.ChartLegend = strconv.Itoa(endYear - lenYear + i)
  847. }
  848. dataMap[k] = v
  849. }
  850. yearDataListMap := make(map[int]*data.EdbDataItems, 0)
  851. for _, lv := range result.List {
  852. yearDataListMap[lv.Year] = lv
  853. }
  854. //判断哪些点应该落在同一条时间线上
  855. /*maxY := lastDateT.Year()
  856. changeFlag := false
  857. if lastDateT.Month() >= 11 {
  858. maxY = maxY + 1
  859. }
  860. if maxY < nowYear {
  861. changeFlag = true
  862. maxY = nowYear
  863. }*/
  864. /*endTmp := fmt.Sprintf("%d-%s", maxY, xEndDate)
  865. endTmpT, _ := time.Parse(utils.FormatDate, endTmp)
  866. minY := maxY
  867. if jumpYear == 1 {
  868. minY = maxY - 1
  869. }
  870. startTmp := fmt.Sprintf("%d-%s", minY, xStartDate)
  871. startTmpT, _ := time.Parse(utils.FormatDate, startTmp)*/
  872. fmt.Println("横轴截取日" + startTmpT.Format(utils.FormatDate) + " " + endTmpT.Format(utils.FormatDate))
  873. fmt.Printf("lastDateT.Year() 为%d \n", lastDateT.Year())
  874. fmt.Printf("maxY 为%d \n", maxY)
  875. for name, dateItem := range dataMap {
  876. tY := dateItem.EndDate.Year()
  877. if lastDateT.Month() >= 11 {
  878. if maxY > endTmpT.Year() {
  879. tY = tY + 1
  880. }
  881. }
  882. lv, ok1 := yearDataListMap[tY]
  883. fmt.Printf("name %s yearDataListMap[%d]\n", name, tY)
  884. if !ok1 {
  885. continue
  886. }
  887. for _, item := range lv.Items {
  888. tmpVal := models.EdbDataList{
  889. EdbDataId: item.EdbDataId,
  890. EdbInfoId: item.EdbInfoId,
  891. DataTime: item.DataTime,
  892. DataTimestamp: item.DataTimestamp,
  893. Value: item.Value,
  894. }
  895. dataTimeT, _ := time.Parse(utils.FormatDate, item.DataTime)
  896. if (startTmpT.Before(dataTimeT) && endTmpT.After(dataTimeT)) || startTmpT == dataTimeT || endTmpT == dataTimeT {
  897. tmpV := &tmpVal
  898. if findVal, ok := quarterMap[name]; !ok {
  899. findVal = append(findVal, tmpV)
  900. quarterMap[name] = findVal
  901. } else {
  902. findVal = append(findVal, tmpV)
  903. quarterMap[name] = findVal
  904. }
  905. if lv.Year >= latestDateYear {
  906. // 切割的日期时间字符串
  907. cuttingDataTimeStr := latestDate.AddDate(0, 0, lv.BetweenDay).Format(utils.FormatDate)
  908. if item.DataTime == cuttingDataTimeStr {
  909. dateItem.CuttingDataTimestamp = tmpVal.DataTimestamp
  910. dataMap[name] = dateItem
  911. }
  912. }
  913. }
  914. }
  915. }
  916. for k, v := range dataMap {
  917. itemList := quarterMap[k]
  918. quarterItem := new(models.QuarterData)
  919. quarterItem.Years = v.ShowName
  920. quarterItem.ChartLegend = v.ChartLegend
  921. if le, ok := legendMap[v.ShowName]; ok {
  922. if le != strconv.Itoa(v.StartDate.Year()) && le != strconv.Itoa(v.EndDate.Year()) {
  923. quarterItem.ChartLegend = le
  924. }
  925. }
  926. quarterItem.DataList = itemList
  927. quarterItem.CuttingDataTimestamp = v.CuttingDataTimestamp
  928. //如果等于最后的实际日期,那么将切割时间戳记录
  929. if quarterItem.CuttingDataTimestamp == 0 {
  930. //如果大于最后的实际日期,那么第一个点就是切割的时间戳
  931. if latestDate.Before(v.StartDate) && len(itemList) > 0 {
  932. quarterItem.CuttingDataTimestamp = itemList[0].DataTimestamp - 100
  933. }
  934. }
  935. quarterDataList = append(quarterDataList, quarterItem)
  936. }
  937. if result.List[0].Year != calendarPreYear {
  938. itemList := make([]*models.EdbDataList, 0)
  939. items := new(models.QuarterData)
  940. //items.Year = calendarPreYear
  941. items.DataList = itemList
  942. newResult := make([]*models.QuarterData, 0)
  943. newResult = append(newResult, items)
  944. newResult = append(newResult, quarterDataList...)
  945. resultData = newResult
  946. } else {
  947. resultData = quarterDataList
  948. }
  949. if len(quarterDataList) > 0 {
  950. quarterDataListSort = resultData
  951. sort.Sort(quarterDataListSort)
  952. }
  953. return
  954. }
  955. // BarChartData 柱方图的数据处理
  956. func BarChartData(mappingList []*models.ChartEdbInfoMapping, edbDataListMap map[int][]*models.EdbDataList, barChartInfoDateList []models.BarChartInfoDateReq, barChartInfoSort models.BarChartInfoSortReq) (edbIdList []int, yDataList []models.YData, err error) {
  957. // 指标数据数组(10086:{"2022-12-02":100.01,"2022-12-01":102.3})
  958. edbDataMap := make(map[int]map[string]float64)
  959. for edbInfoId, edbDataList := range edbDataListMap {
  960. edbDateData := make(map[string]float64)
  961. for _, edbData := range edbDataList {
  962. edbDateData[edbData.DataTime] = edbData.Value
  963. }
  964. edbDataMap[edbInfoId] = edbDateData
  965. }
  966. // edbIdList 指标展示顺序;x轴的指标顺序
  967. edbIdList = make([]int, 0)
  968. //Sort int `description:"排序类型,0:默认,1:升序,2:降序"`
  969. dateData := make(map[int]float64)
  970. if barChartInfoSort.Sort == 0 {
  971. for _, v := range mappingList {
  972. edbIdList = append(edbIdList, v.EdbInfoId)
  973. }
  974. } else {
  975. lenBarChartInfoDateList := len(barChartInfoDateList)
  976. if barChartInfoSort.DateIndex >= lenBarChartInfoDateList {
  977. err = errors.New("排序日期异常")
  978. return
  979. }
  980. notDataEdbIdList := make([]int, 0) //没有数据的指标id
  981. // 日期配置
  982. barChartInfoDate := barChartInfoDateList[barChartInfoSort.DateIndex]
  983. for edbInfoId, dataList := range edbDataListMap {
  984. if len(dataList) <= 0 {
  985. // 没有数据的指标id
  986. notDataEdbIdList = append(notDataEdbIdList, edbInfoId)
  987. continue
  988. }
  989. findDate := barChartInfoDate.Date
  990. switch barChartInfoDate.Type {
  991. case 1: //最新值
  992. findDate = dataList[len(dataList)-1].DataTime
  993. case 2: //近期几天
  994. findDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[len(dataList)-1].DataTime, time.Local)
  995. if tmpErr != nil {
  996. err = tmpErr
  997. return
  998. }
  999. findDateTime = findDateTime.AddDate(0, 0, -barChartInfoDate.Value)
  1000. lenData := len(dataList) - 1
  1001. for i := lenData; i >= 0; i-- {
  1002. currDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[i].DataTime, time.Local)
  1003. if tmpErr != nil {
  1004. err = tmpErr
  1005. return
  1006. }
  1007. if currDateTime.Equal(findDateTime) || currDateTime.Before(findDateTime) {
  1008. findDate = dataList[i].DataTime
  1009. break
  1010. }
  1011. }
  1012. case 3: // 固定日期
  1013. //最早的日期
  1014. minDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[0].DataTime, time.Local)
  1015. if tmpErr != nil {
  1016. err = tmpErr
  1017. return
  1018. }
  1019. //寻找固定日期的数据
  1020. findDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, barChartInfoDate.Date, time.Local)
  1021. if tmpErr != nil {
  1022. err = tmpErr
  1023. return
  1024. }
  1025. for tmpDateTime := findDateTime; tmpDateTime.After(minDateTime) || tmpDateTime.Equal(minDateTime); tmpDateTime = tmpDateTime.AddDate(0, 0, -1) {
  1026. tmpDate := tmpDateTime.Format(utils.FormatDate)
  1027. if _, ok := edbDataMap[edbInfoId][tmpDate]; ok { //如果能找到数据,那么就返回
  1028. findDate = tmpDate
  1029. break
  1030. }
  1031. }
  1032. default:
  1033. err = errors.New(fmt.Sprint("日期类型异常,Type:", barChartInfoDate.Type))
  1034. return
  1035. }
  1036. if tmpValue, ok := edbDataMap[edbInfoId][findDate]; ok {
  1037. dateData[edbInfoId] = tmpValue
  1038. } else {
  1039. // 没有数据的指标id
  1040. notDataEdbIdList = append(notDataEdbIdList, edbInfoId)
  1041. }
  1042. }
  1043. //Sort int `description:"排序类型,0:默认,1:升序,2:降序"`
  1044. // 排序
  1045. dateDataSort := utils.NewMapSorter(dateData)
  1046. sort.Sort(dateDataSort)
  1047. if barChartInfoSort.Sort == 1 {
  1048. // 先将没有数据的指标id放在最前面
  1049. if len(notDataEdbIdList) > 0 {
  1050. edbIdList = append(edbIdList, notDataEdbIdList...)
  1051. }
  1052. for _, v := range dateDataSort {
  1053. edbIdList = append(edbIdList, v.Key)
  1054. }
  1055. } else {
  1056. for i := len(dateDataSort) - 1; i >= 0; i-- {
  1057. edbIdList = append(edbIdList, dateDataSort[i].Key)
  1058. }
  1059. // 再将没有数据的指标id放在最后面
  1060. if len(notDataEdbIdList) > 0 {
  1061. edbIdList = append(edbIdList, notDataEdbIdList...)
  1062. }
  1063. }
  1064. }
  1065. yDataList = make([]models.YData, 0) //y轴的数据列表
  1066. for _, barChartInfoDate := range barChartInfoDateList {
  1067. var maxDate time.Time
  1068. findDataList := make([]float64, 0) // 当前日期的数据值
  1069. for _, edbInfoId := range edbIdList {
  1070. findDate := barChartInfoDate.Date //需要的日期值
  1071. dataList := edbDataListMap[edbInfoId] //指标的所有数据值
  1072. if len(dataList) <= 0 {
  1073. // 没有数据的指标id
  1074. findDataList = append(findDataList, 0)
  1075. continue
  1076. }
  1077. switch barChartInfoDate.Type {
  1078. case 1: //最新值
  1079. dataList := edbDataListMap[edbInfoId]
  1080. findDate = dataList[len(dataList)-1].DataTime
  1081. case 2: //近期几天
  1082. findDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[len(dataList)-1].DataTime, time.Local)
  1083. if tmpErr != nil {
  1084. err = tmpErr
  1085. return
  1086. }
  1087. findDateTime = findDateTime.AddDate(0, 0, -barChartInfoDate.Value)
  1088. lenData := len(dataList) - 1
  1089. for i := lenData; i >= 0; i-- {
  1090. currDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[i].DataTime, time.Local)
  1091. if tmpErr != nil {
  1092. err = tmpErr
  1093. return
  1094. }
  1095. if currDateTime.Equal(findDateTime) || currDateTime.Before(findDateTime) {
  1096. findDate = dataList[i].DataTime
  1097. break
  1098. }
  1099. }
  1100. case 3: // 固定日期
  1101. //最早的日期
  1102. minDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[0].DataTime, time.Local)
  1103. if tmpErr != nil {
  1104. err = tmpErr
  1105. return
  1106. }
  1107. //寻找固定日期的数据
  1108. findDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, barChartInfoDate.Date, time.Local)
  1109. if tmpErr != nil {
  1110. err = tmpErr
  1111. return
  1112. }
  1113. for tmpDateTime := findDateTime; tmpDateTime.After(minDateTime) || tmpDateTime.Equal(minDateTime); tmpDateTime = tmpDateTime.AddDate(0, 0, -1) {
  1114. tmpDate := tmpDateTime.Format(utils.FormatDate)
  1115. if _, ok := edbDataMap[edbInfoId][tmpDate]; ok { //如果能找到数据,那么就返回
  1116. findDate = tmpDate
  1117. break
  1118. }
  1119. }
  1120. default:
  1121. err = errors.New(fmt.Sprint("日期类型异常,Type:", barChartInfoDate.Type))
  1122. return
  1123. }
  1124. findDateTime, _ := time.ParseInLocation(utils.FormatDate, findDate, time.Local)
  1125. if maxDate.IsZero() {
  1126. maxDate = findDateTime
  1127. } else {
  1128. if findDateTime.After(maxDate) {
  1129. maxDate = findDateTime
  1130. }
  1131. }
  1132. if tmpValue, ok := edbDataMap[edbInfoId][findDate]; ok {
  1133. tmpValue, _ = decimal.NewFromFloat(tmpValue).Round(4).Float64()
  1134. findDataList = append(findDataList, tmpValue)
  1135. } else {
  1136. findDataList = append(findDataList, 0)
  1137. }
  1138. }
  1139. yDate := "0000-00-00"
  1140. if !maxDate.IsZero() {
  1141. yDate = maxDate.Format(utils.FormatDate)
  1142. }
  1143. yDataList = append(yDataList, models.YData{
  1144. Date: yDate,
  1145. Value: findDataList,
  1146. Color: barChartInfoDate.Color,
  1147. Name: barChartInfoDate.Name,
  1148. })
  1149. }
  1150. return
  1151. }
  1152. func CheckIsEnChart(chartNameEn string, edbList []*models.ChartEdbInfoMapping, source, chartType int) bool {
  1153. // 相关性图表不判断指标
  1154. if utils.InArrayByInt([]int{utils.CHART_SOURCE_CORRELATION, utils.CHART_SOURCE_ROLLING_CORRELATION, utils.CHART_SOURCE_LINE_EQUATION}, source) && chartNameEn != "" {
  1155. return true
  1156. }
  1157. if chartNameEn != "" && len(edbList) <= 0 {
  1158. return true
  1159. }
  1160. if chartNameEn == "" {
  1161. return false
  1162. }
  1163. // 截面散点图的话,肯定是有英文配置的
  1164. if chartType == utils.CHART_TYPE_SECTION_SCATTER {
  1165. return true
  1166. }
  1167. for _, v := range edbList {
  1168. if v.EdbNameEn == "" {
  1169. return false
  1170. }
  1171. if v.Unit != "无" && v.Unit != "" && v.UnitEn == "" {
  1172. return false
  1173. }
  1174. }
  1175. return true
  1176. }
  1177. func CheckIsEnEdb(edbNameEn, unit, unitEn string) bool {
  1178. if edbNameEn == "" {
  1179. return false
  1180. }
  1181. if unit != "无" && unit != "" && unitEn == "" {
  1182. return false
  1183. }
  1184. return true
  1185. }
  1186. // CheckChartExtraConfig 校验图表额外配置的信息,并且获取相关联的指标id
  1187. func CheckChartExtraConfig(chartType int, extraConfigStr string) (edbIdList []int, err error, errMsg string) {
  1188. switch chartType {
  1189. case 10: //截面散点
  1190. var extraConfig models.SectionScatterReq
  1191. err = json.Unmarshal([]byte(extraConfigStr), &extraConfig)
  1192. if err != nil {
  1193. return
  1194. }
  1195. // 判断是否有配置日期序列
  1196. if len(extraConfig.SeriesList) <= 0 {
  1197. errMsg = `请配置序列`
  1198. err = errors.New(errMsg)
  1199. return
  1200. }
  1201. // 判断是否有填写指标
  1202. if len(extraConfig.SeriesList[0].EdbInfoList) <= 0 {
  1203. errMsg = `请选择指标`
  1204. err = errors.New(errMsg)
  1205. return
  1206. }
  1207. // 遍历指标列表获取指标id
  1208. edbIdMap := make(map[int]int)
  1209. for _, v := range extraConfig.SeriesList[0].EdbInfoList {
  1210. // X 轴的指标id
  1211. if _, ok := edbIdMap[v.XEdbInfoId]; !ok {
  1212. edbIdMap[v.XEdbInfoId] = v.XEdbInfoId
  1213. edbIdList = append(edbIdList, v.XEdbInfoId)
  1214. }
  1215. // Y 轴的指标id
  1216. if _, ok := edbIdMap[v.YEdbInfoId]; !ok {
  1217. edbIdMap[v.YEdbInfoId] = v.YEdbInfoId
  1218. edbIdList = append(edbIdList, v.YEdbInfoId)
  1219. }
  1220. }
  1221. case utils.CHART_TYPE_RADAR:
  1222. var extraConfig models.RadarChartInfoReq
  1223. if extraConfigStr == `` {
  1224. errMsg = "雷达图未配置"
  1225. err = errors.New(errMsg)
  1226. return
  1227. }
  1228. err = json.Unmarshal([]byte(extraConfigStr), &extraConfig)
  1229. if err != nil {
  1230. errMsg = "雷达图配置异常"
  1231. err = errors.New(errMsg)
  1232. return
  1233. }
  1234. }
  1235. return
  1236. }
  1237. // GetSectionScatterChartData 截面散点图的数据处理
  1238. func GetSectionScatterChartData(chartInfoId int, mappingList []*models.ChartEdbInfoMapping, edbDataListMap map[int][]*models.EdbDataList, extraConfig models.SectionScatterReq) (edbIdList []int, chartDataResp models.SectionScatterInfoResp, err error) {
  1239. // 指标数据数组(10086:{"2022-12-02":100.01,"2022-12-01":102.3})
  1240. edbDataMap := make(map[int]map[string]float64)
  1241. for edbInfoId, edbDataList := range edbDataListMap {
  1242. edbDateData := make(map[string]float64)
  1243. for _, edbData := range edbDataList {
  1244. edbDateData[edbData.DataTime] = edbData.Value
  1245. }
  1246. edbDataMap[edbInfoId] = edbDateData
  1247. }
  1248. // edbIdList 指标展示顺序;x轴的指标顺序
  1249. edbIdList = make([]int, 0)
  1250. edbMappingMap := make(map[int]*models.ChartEdbInfoMapping)
  1251. for _, v := range mappingList {
  1252. edbIdList = append(edbIdList, v.EdbInfoId)
  1253. edbMappingMap[v.EdbInfoId] = v
  1254. }
  1255. //SectionScatterSeriesInfoResp
  1256. dataListResp := make([]models.SectionScatterSeriesItemResp, 0) //y轴的数据列表
  1257. for _, seriesItem := range extraConfig.SeriesList {
  1258. var maxDate time.Time
  1259. // 系列中的指标数据
  1260. tmpSeriesEdbInfoList := make([]models.SectionScatterEdbItemResp, 0)
  1261. var minXVal, maxXVal, minYVal, maxYVal float64
  1262. for _, edbConf := range seriesItem.EdbInfoList {
  1263. tmpItem := models.SectionScatterEdbItemResp{
  1264. IsShow: edbConf.IsShow,
  1265. Name: edbConf.Name,
  1266. NameEn: edbConf.NameEn,
  1267. } //单个坐标点的数据
  1268. //X轴的数据
  1269. {
  1270. edbInfoId := edbConf.XEdbInfoId //X轴的指标
  1271. edbMappingInfo, ok := edbMappingMap[edbInfoId]
  1272. if !ok {
  1273. continue
  1274. }
  1275. findDate := edbConf.XDate //需要的日期值
  1276. dataList := edbDataListMap[edbInfoId] //指标的所有数据值
  1277. if len(dataList) <= 0 {
  1278. // 没有数据的指标id
  1279. //findDataList = append(findDataList, 0)
  1280. continue
  1281. }
  1282. tmpItem.XEdbInfoId = edbInfoId
  1283. tmpItem.XName = edbMappingInfo.EdbName
  1284. tmpItem.XNameEn = edbMappingInfo.EdbNameEn
  1285. switch edbConf.XDateType {
  1286. case 1: //最新值
  1287. findDate = dataList[len(dataList)-1].DataTime
  1288. case 2: //近期几天
  1289. findDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[len(dataList)-1].DataTime, time.Local)
  1290. if tmpErr != nil {
  1291. err = tmpErr
  1292. return
  1293. }
  1294. findDateTime = findDateTime.AddDate(0, 0, -edbConf.XDateValue)
  1295. lenData := len(dataList) - 1
  1296. for i := lenData; i >= 0; i-- {
  1297. currDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[i].DataTime, time.Local)
  1298. if tmpErr != nil {
  1299. err = tmpErr
  1300. return
  1301. }
  1302. if currDateTime.Equal(findDateTime) || currDateTime.Before(findDateTime) {
  1303. findDate = dataList[i].DataTime
  1304. break
  1305. }
  1306. }
  1307. case 3: // 固定日期
  1308. //最早的日期
  1309. minDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[0].DataTime, time.Local)
  1310. if tmpErr != nil {
  1311. err = tmpErr
  1312. return
  1313. }
  1314. //寻找固定日期的数据
  1315. findDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, edbConf.XDate, time.Local)
  1316. if tmpErr != nil {
  1317. err = tmpErr
  1318. return
  1319. }
  1320. for tmpDateTime := findDateTime; tmpDateTime.After(minDateTime) || tmpDateTime.Equal(minDateTime); tmpDateTime = tmpDateTime.AddDate(0, 0, -1) {
  1321. tmpDate := tmpDateTime.Format(utils.FormatDate)
  1322. if _, ok := edbDataMap[edbInfoId][tmpDate]; ok { //如果能找到数据,那么就返回
  1323. findDate = tmpDate
  1324. break
  1325. }
  1326. }
  1327. default:
  1328. err = errors.New(fmt.Sprint("日期类型异常,Type:", edbConf.XDate))
  1329. return
  1330. }
  1331. findDateTime, _ := time.ParseInLocation(utils.FormatDate, findDate, time.Local)
  1332. if maxDate.IsZero() {
  1333. maxDate = findDateTime
  1334. } else {
  1335. if findDateTime.After(maxDate) {
  1336. maxDate = findDateTime
  1337. }
  1338. }
  1339. if tmpValue, ok := edbDataMap[edbInfoId][findDate]; ok {
  1340. tmpItem.XDate = findDate
  1341. tmpItem.XValue = tmpValue
  1342. } else {
  1343. continue
  1344. }
  1345. }
  1346. //Y轴的数据
  1347. {
  1348. edbInfoId := edbConf.YEdbInfoId //Y轴的指标
  1349. edbMappingInfo, ok := edbMappingMap[edbInfoId]
  1350. if !ok {
  1351. continue
  1352. }
  1353. findDate := edbConf.YDate //需要的日期值
  1354. dataList := edbDataListMap[edbInfoId] //指标的所有数据值
  1355. if len(dataList) <= 0 {
  1356. // 没有数据的指标id
  1357. //findDataList = append(findDataList, 0)
  1358. continue
  1359. }
  1360. tmpItem.YEdbInfoId = edbInfoId
  1361. tmpItem.YName = edbMappingInfo.EdbName
  1362. tmpItem.YNameEn = edbMappingInfo.EdbNameEn
  1363. switch edbConf.YDateType {
  1364. case 1: //最新值
  1365. findDate = dataList[len(dataList)-1].DataTime
  1366. case 2: //近期几天
  1367. findDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[len(dataList)-1].DataTime, time.Local)
  1368. if tmpErr != nil {
  1369. err = tmpErr
  1370. return
  1371. }
  1372. findDateTime = findDateTime.AddDate(0, 0, -edbConf.YDateValue)
  1373. lenData := len(dataList) - 1
  1374. for i := lenData; i >= 0; i-- {
  1375. currDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[i].DataTime, time.Local)
  1376. if tmpErr != nil {
  1377. err = tmpErr
  1378. return
  1379. }
  1380. if currDateTime.Equal(findDateTime) || currDateTime.Before(findDateTime) {
  1381. findDate = dataList[i].DataTime
  1382. break
  1383. }
  1384. }
  1385. case 3: // 固定日期
  1386. //最早的日期
  1387. minDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[0].DataTime, time.Local)
  1388. if tmpErr != nil {
  1389. err = tmpErr
  1390. return
  1391. }
  1392. //寻找固定日期的数据
  1393. findDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, edbConf.YDate, time.Local)
  1394. if tmpErr != nil {
  1395. err = tmpErr
  1396. return
  1397. }
  1398. for tmpDateTime := findDateTime; tmpDateTime.After(minDateTime) || tmpDateTime.Equal(minDateTime); tmpDateTime = tmpDateTime.AddDate(0, 0, -1) {
  1399. tmpDate := tmpDateTime.Format(utils.FormatDate)
  1400. if _, ok := edbDataMap[edbInfoId][tmpDate]; ok { //如果能找到数据,那么就返回
  1401. findDate = tmpDate
  1402. break
  1403. }
  1404. }
  1405. default:
  1406. err = errors.New(fmt.Sprint("日期类型异常,Type:", edbConf.YDate))
  1407. return
  1408. }
  1409. findDateTime, _ := time.ParseInLocation(utils.FormatDate, findDate, time.Local)
  1410. if maxDate.IsZero() {
  1411. maxDate = findDateTime
  1412. } else {
  1413. if findDateTime.After(maxDate) {
  1414. maxDate = findDateTime
  1415. }
  1416. }
  1417. if tmpValue, ok := edbDataMap[edbInfoId][findDate]; ok {
  1418. tmpItem.YDate = findDate
  1419. tmpItem.YValue = tmpValue
  1420. } else {
  1421. continue
  1422. }
  1423. }
  1424. // 获取当前系列的X轴的最大最小值
  1425. {
  1426. if tmpItem.XValue < minXVal {
  1427. minXVal = tmpItem.XValue
  1428. }
  1429. if tmpItem.XValue > maxXVal {
  1430. maxXVal = tmpItem.XValue
  1431. }
  1432. if tmpItem.YValue < minYVal {
  1433. minYVal = tmpItem.YValue
  1434. }
  1435. if tmpItem.YValue > maxYVal {
  1436. maxYVal = tmpItem.YValue
  1437. }
  1438. }
  1439. tmpSeriesEdbInfoList = append(tmpSeriesEdbInfoList, tmpItem)
  1440. }
  1441. trendLimitData := make([]models.CoordinatePoint, 0) //趋势线的前后坐标点
  1442. var trendLine, rSquare string
  1443. // 生成线性方程式
  1444. var a, b float64
  1445. {
  1446. coordinateData := make([]utils.Coordinate, 0)
  1447. for _, tmpSeriesEdbInfo := range tmpSeriesEdbInfoList {
  1448. tmpCoordinate1 := utils.Coordinate{
  1449. X: tmpSeriesEdbInfo.XValue,
  1450. Y: tmpSeriesEdbInfo.YValue,
  1451. }
  1452. coordinateData = append(coordinateData, tmpCoordinate1)
  1453. }
  1454. // 只有存在两个坐标点的时候,才能去计算线性方程和R平方
  1455. if len(coordinateData) >= 2 {
  1456. a, b = utils.GetLinearResult(coordinateData)
  1457. if !math.IsNaN(a) && !math.IsNaN(b) {
  1458. if b > 0 {
  1459. trendLine = fmt.Sprintf("y=%sx+%s", utils.SubFloatToString(a, 4), utils.SubFloatToString(b, 4))
  1460. } else {
  1461. trendLine = fmt.Sprintf("y=%sx%s", utils.SubFloatToString(a, 4), utils.SubFloatToString(b, 4))
  1462. }
  1463. minYVal, _ = decimal.NewFromFloat(a).Mul(decimal.NewFromFloat(minXVal)).Add(decimal.NewFromFloat(b)).Round(4).Float64()
  1464. maxYVal, _ = decimal.NewFromFloat(a).Mul(decimal.NewFromFloat(maxXVal)).Add(decimal.NewFromFloat(b)).Round(4).Float64()
  1465. }
  1466. // 计算R平方
  1467. rSquare = fmt.Sprint(utils.CalculationDecisive(coordinateData))
  1468. }
  1469. trendLimitData = append(trendLimitData, models.CoordinatePoint{
  1470. X: minXVal,
  1471. Y: minYVal,
  1472. }, models.CoordinatePoint{
  1473. X: maxXVal,
  1474. Y: maxYVal,
  1475. })
  1476. }
  1477. dataListResp = append(dataListResp, models.SectionScatterSeriesItemResp{
  1478. Name: seriesItem.Name,
  1479. NameEn: seriesItem.NameEn,
  1480. IsNameDefault: seriesItem.IsNameDefault,
  1481. Color: seriesItem.Color,
  1482. EdbInfoList: tmpSeriesEdbInfoList,
  1483. ShowTrendLine: seriesItem.ShowTrendLine,
  1484. ShowFitEquation: seriesItem.ShowFitEquation,
  1485. ShowRSquare: seriesItem.ShowRSquare,
  1486. TrendLine: trendLine,
  1487. RSquare: rSquare,
  1488. TrendLimitData: trendLimitData,
  1489. })
  1490. }
  1491. // 截面散点图点击详情时自动更新系列名
  1492. if len(extraConfig.SeriesList) > 0 {
  1493. // 默认名字的时候才自动更新
  1494. if extraConfig.SeriesList[0].IsNameDefault {
  1495. firstXEdbInfoId := extraConfig.SeriesList[0].EdbInfoList[0].XEdbInfoId
  1496. needUpdate := false
  1497. if v, ok := edbMappingMap[firstXEdbInfoId]; ok {
  1498. extraConfig.SeriesList[0].Name = v.LatestDate
  1499. extraConfig.SeriesList[0].NameEn = v.LatestDate
  1500. dataListResp[0].Name = v.LatestDate
  1501. dataListResp[0].NameEn = v.LatestDate
  1502. needUpdate = true
  1503. }
  1504. extraConfigByte, e := json.Marshal(extraConfig)
  1505. if e != nil {
  1506. errMsg := "截面散点系列更新异常"
  1507. err = errors.New(errMsg)
  1508. return
  1509. }
  1510. extraConfigStr := string(extraConfigByte)
  1511. if needUpdate {
  1512. err = models.EditChartInfoExtraConfig(chartInfoId, extraConfigStr)
  1513. if err != nil {
  1514. errMsg := "截面散点系列更新异常"
  1515. err = errors.New(errMsg)
  1516. return
  1517. }
  1518. }
  1519. }
  1520. }
  1521. chartDataResp = models.SectionScatterInfoResp{
  1522. XName: extraConfig.XName,
  1523. XNameEn: extraConfig.XNameEn,
  1524. XUnitName: extraConfig.XUnitName,
  1525. XUnitNameEn: extraConfig.XUnitNameEn,
  1526. YName: extraConfig.YName,
  1527. YNameEn: extraConfig.YNameEn,
  1528. YUnitName: extraConfig.YUnitName,
  1529. YUnitNameEn: extraConfig.YUnitNameEn,
  1530. XMinValue: extraConfig.XMinValue,
  1531. XMaxValue: extraConfig.XMaxValue,
  1532. YMinValue: extraConfig.YMinValue,
  1533. YMaxValue: extraConfig.YMaxValue,
  1534. DataList: dataListResp,
  1535. }
  1536. return
  1537. }
  1538. // GetEdbSourceByEdbInfoIdList 获取关联指标的来源
  1539. func GetEdbSourceByEdbInfoIdList(chartEdbInfoMappingList []*models.ChartEdbInfoMapping) (sourceNameList, sourceNameEnList []string) {
  1540. sourceNameList = make([]string, 0)
  1541. sourceNameEnList = make([]string, 0)
  1542. sourceMap := make(map[int]string)
  1543. for _, v := range chartEdbInfoMappingList {
  1544. // 指标类型:1:基础指标,2:计算指标
  1545. if v.EdbType == 2 || v.EdbInfoCategoryType == 1 {
  1546. //sourceMap[0] = "弘则研究"
  1547. baseEdbInfoArr, _, _ := GetRefreshEdbInfoFromBase(v.EdbInfoId, v.Source)
  1548. for _, baseEdbInfo := range baseEdbInfoArr {
  1549. if baseEdbInfo.EdbInfoType == 0 { //普通指标才参与,预测指标不参与
  1550. sourceMap[baseEdbInfo.Source] = baseEdbInfo.SourceName
  1551. }
  1552. }
  1553. } else {
  1554. sourceMap[v.Source] = v.SourceName
  1555. }
  1556. }
  1557. for source, sourceName := range sourceMap {
  1558. if utils.InArrayByInt([]int{utils.DATA_SOURCE_MANUAL, utils.DATA_SOURCE_MYSTEEL_CHEMICAL}, source) {
  1559. continue
  1560. }
  1561. sourceNameList = append(sourceNameList, sourceName)
  1562. sourceNameEn, ok := utils.DataSourceEnMap[source]
  1563. if !ok {
  1564. sourceNameEn = sourceName
  1565. }
  1566. sourceNameEnList = append(sourceNameEnList, sourceNameEn)
  1567. }
  1568. //sourceNameList = append(sourceNameList, utils.ChartDefaultNameCn)
  1569. //sourceNameEnList = append(sourceNameEnList, utils.ChartDefaultNameEn)
  1570. // 图表来源
  1571. /*conf, e := models.GetBusinessConf()
  1572. if e != nil {
  1573. return
  1574. }
  1575. if conf[models.BusinessConfCompanyName] != "" {
  1576. sourceNameList = append(sourceNameList, conf[models.BusinessConfCompanyName])
  1577. sourceNameEnList = append(sourceNameEnList, conf[models.BusinessConfCompanyName])
  1578. }*/
  1579. return
  1580. }
  1581. // RadarChartData 雷达图的数据处理
  1582. func RadarChartData(mappingList []*models.ChartEdbInfoMapping, edbDataListMap map[int][]*models.EdbDataList, extraConfig models.RadarChartInfoReq) (edbIdList []int, chartDataResp models.RadarChartInfoResp, err error) {
  1583. // 指标数据数组(10086:{"2022-12-02":100.01,"2022-12-01":102.3})
  1584. edbDataMap := make(map[int]map[string]float64)
  1585. for edbInfoId, edbDataList := range edbDataListMap {
  1586. edbDateData := make(map[string]float64)
  1587. for _, edbData := range edbDataList {
  1588. edbDateData[edbData.DataTime] = edbData.Value
  1589. }
  1590. edbDataMap[edbInfoId] = edbDateData
  1591. }
  1592. // edbIdList 指标展示顺序;x轴的指标顺序
  1593. edbIdList = make([]int, 0)
  1594. for _, v := range mappingList {
  1595. edbIdList = append(edbIdList, v.EdbInfoId)
  1596. }
  1597. chartDateList := extraConfig.DateList
  1598. yDataList := make([]models.RadarYData, 0) //y轴的数据列表
  1599. for _, chartDate := range chartDateList {
  1600. var maxDate time.Time
  1601. findDataList := make([]float64, 0) // 当前日期的数据值
  1602. for _, edbInfoId := range edbIdList {
  1603. findDate := chartDate.Date //需要的日期值
  1604. dataList := edbDataListMap[edbInfoId] //指标的所有数据值
  1605. if len(dataList) <= 0 {
  1606. // 没有数据的指标id
  1607. findDataList = append(findDataList, 0)
  1608. continue
  1609. }
  1610. switch chartDate.Type {
  1611. case 1: //最新值
  1612. findDate = dataList[len(dataList)-1].DataTime
  1613. case 2: //近期几天
  1614. findDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[len(dataList)-1].DataTime, time.Local)
  1615. if tmpErr != nil {
  1616. err = tmpErr
  1617. return
  1618. }
  1619. findDateTime = findDateTime.AddDate(0, 0, -chartDate.Value)
  1620. lenData := len(dataList) - 1
  1621. for i := lenData; i >= 0; i-- {
  1622. currDateTime, e := time.ParseInLocation(utils.FormatDate, dataList[i].DataTime, time.Local)
  1623. if e != nil {
  1624. err = e
  1625. return
  1626. }
  1627. if currDateTime.Equal(findDateTime) || currDateTime.Before(findDateTime) {
  1628. findDate = dataList[i].DataTime
  1629. break
  1630. }
  1631. }
  1632. case 3: // 固定日期
  1633. //最早的日期
  1634. minDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, dataList[0].DataTime, time.Local)
  1635. if tmpErr != nil {
  1636. err = tmpErr
  1637. return
  1638. }
  1639. //寻找固定日期的数据
  1640. findDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, chartDate.Date, time.Local)
  1641. if tmpErr != nil {
  1642. err = tmpErr
  1643. return
  1644. }
  1645. for tmpDateTime := findDateTime; tmpDateTime.After(minDateTime) || tmpDateTime.Equal(minDateTime); tmpDateTime = tmpDateTime.AddDate(0, 0, -1) {
  1646. tmpDate := tmpDateTime.Format(utils.FormatDate)
  1647. if _, ok := edbDataMap[edbInfoId][tmpDate]; ok { //如果能找到数据,那么就返回
  1648. findDate = tmpDate
  1649. break
  1650. }
  1651. }
  1652. default:
  1653. err = errors.New(fmt.Sprint("日期类型异常,Type:", chartDate.Type))
  1654. return
  1655. }
  1656. findDateTime, _ := time.ParseInLocation(utils.FormatDate, findDate, time.Local)
  1657. if maxDate.IsZero() {
  1658. maxDate = findDateTime
  1659. } else {
  1660. if findDateTime.After(maxDate) {
  1661. maxDate = findDateTime
  1662. }
  1663. }
  1664. if tmpValue, ok := edbDataMap[edbInfoId][findDate]; ok {
  1665. tmpValue, _ = decimal.NewFromFloat(tmpValue).Round(4).Float64()
  1666. findDataList = append(findDataList, tmpValue)
  1667. } else {
  1668. findDataList = append(findDataList, 0)
  1669. }
  1670. }
  1671. yDate := "0000-00-00"
  1672. if !maxDate.IsZero() {
  1673. yDate = maxDate.Format(utils.FormatDate)
  1674. }
  1675. yDataList = append(yDataList, models.RadarYData{
  1676. Date: yDate,
  1677. Value: findDataList,
  1678. Color: chartDate.Color,
  1679. Name: chartDate.Name,
  1680. })
  1681. }
  1682. chartDataResp = models.RadarChartInfoResp{
  1683. YDataList: yDataList,
  1684. XEdbIdValue: edbIdList,
  1685. }
  1686. return
  1687. }
  1688. // SeasonChartData 季节性图的数据处理
  1689. func SeasonChartData(dataList []*models.ChartEdbInfoMapping, seasonExtraConfig string) (dataResp models.SeasonChartResp, err error) {
  1690. var seasonConfig models.SeasonExtraItem
  1691. err = json.Unmarshal([]byte(seasonExtraConfig), &seasonConfig)
  1692. if err != nil {
  1693. err = errors.New("季节性图配置异常, Err:" + err.Error())
  1694. return
  1695. }
  1696. for _, mappingItem := range dataList {
  1697. if mappingItem.IsAxis == 0 {
  1698. continue
  1699. }
  1700. quarterDataList, ok := mappingItem.DataList.(models.QuarterDataList)
  1701. if !ok {
  1702. continue
  1703. }
  1704. // 上下限区间
  1705. if seasonConfig.MaxMinLimits.Year > 0 {
  1706. startYear := time.Now().AddDate(-seasonConfig.MaxMinLimits.Year, 0, 0).Year()
  1707. dataResp.MaxMinLimits.List = make([]*models.MaxMinLimitsData, 0)
  1708. dataTimeMap := make(map[time.Time]time.Time)
  1709. dataTimeList := make([]string, 0)
  1710. maxValueMap := make(map[time.Time]float64)
  1711. minValueMap := make(map[time.Time]float64)
  1712. maxMinDataList := make([]*models.MaxMinLimitsData, 0)
  1713. var startDateStr string
  1714. var endDateStr string
  1715. var newDate time.Time
  1716. startDateStr = fmt.Sprintf("%d-%s", time.Now().Year(), seasonConfig.XStartDate)
  1717. endDateStr = fmt.Sprintf("%d-%s", time.Now().Year(), seasonConfig.XEndDate)
  1718. startDate, e := time.Parse(utils.FormatDate, startDateStr)
  1719. if e != nil {
  1720. err = e
  1721. return
  1722. }
  1723. endDate, e := time.Parse(utils.FormatDate, endDateStr)
  1724. if e != nil {
  1725. err = e
  1726. return
  1727. }
  1728. // 日度 周度插值
  1729. for _, v := range quarterDataList {
  1730. if mappingItem.Frequency == "日度" || mappingItem.Frequency == "周度" {
  1731. handleDataMap := make(map[string]float64)
  1732. dataTimeList, _, err = HandleDataByLinearRegressionToList(v.DataList, handleDataMap)
  1733. if err != nil {
  1734. err = errors.New("插值处理数据异常, Err:" + err.Error())
  1735. return
  1736. }
  1737. // 不包含当年
  1738. if v.ChartLegend == strconv.Itoa(time.Now().Year()) {
  1739. continue
  1740. }
  1741. for _, date := range dataTimeList {
  1742. dateTime, e := time.Parse(utils.FormatDate, date)
  1743. if e != nil {
  1744. err = errors.New("时间格式化异常, Err:" + e.Error())
  1745. return
  1746. }
  1747. if dateTime.Year() < startYear {
  1748. continue
  1749. }
  1750. // 不包含2月29号
  1751. if dateTime.Month() == 2 && dateTime.Day() == 29 {
  1752. continue
  1753. }
  1754. newDate = dateTime.AddDate(time.Now().Year()-dateTime.Year(), 0, 0)
  1755. if seasonConfig.JumpYear == 1 {
  1756. if startDate.After(endDate) {
  1757. // 如果跨年且不到一年
  1758. // 全年截取一部分
  1759. if newDate.Before(startDate.AddDate(0, 0, 1)) && newDate.After(endDate) {
  1760. continue
  1761. }
  1762. if newDate.After(startDate.AddDate(0, 0, -1)) {
  1763. // 减一年
  1764. newDate = dateTime.AddDate(time.Now().Year()-dateTime.Year()-1, 0, 0)
  1765. }
  1766. // 处理上下限列表
  1767. if value, ok := maxValueMap[newDate]; ok {
  1768. if value < handleDataMap[date] {
  1769. maxValueMap[newDate] = handleDataMap[date]
  1770. }
  1771. } else {
  1772. maxValueMap[newDate] = handleDataMap[date]
  1773. }
  1774. if value, ok := minValueMap[newDate]; ok {
  1775. if value > handleDataMap[date] {
  1776. minValueMap[newDate] = handleDataMap[date]
  1777. }
  1778. } else {
  1779. minValueMap[newDate] = handleDataMap[date]
  1780. }
  1781. dataTimeMap[newDate] = newDate
  1782. } else {
  1783. // 如果跨年且大于等于一年
  1784. // double后截取
  1785. if newDate.After(startDate) {
  1786. // 处理上下限列表
  1787. if value, ok := maxValueMap[newDate]; ok {
  1788. if value < handleDataMap[date] {
  1789. maxValueMap[newDate] = handleDataMap[date]
  1790. }
  1791. } else {
  1792. maxValueMap[newDate] = handleDataMap[date]
  1793. }
  1794. if value, ok := minValueMap[newDate]; ok {
  1795. if value > handleDataMap[date] {
  1796. minValueMap[newDate] = handleDataMap[date]
  1797. }
  1798. } else {
  1799. minValueMap[newDate] = handleDataMap[date]
  1800. }
  1801. dataTimeMap[newDate] = newDate
  1802. }
  1803. newDate = dateTime.AddDate(time.Now().Year()-dateTime.Year()+1, 0, 0)
  1804. newEndDate := endDate.AddDate(1, 0, 0)
  1805. if newDate.Before(newEndDate) {
  1806. // 处理上下限列表
  1807. if value, ok := maxValueMap[newDate]; ok {
  1808. if value < handleDataMap[date] {
  1809. maxValueMap[newDate] = handleDataMap[date]
  1810. }
  1811. } else {
  1812. maxValueMap[newDate] = handleDataMap[date]
  1813. }
  1814. if value, ok := minValueMap[newDate]; ok {
  1815. if value > handleDataMap[date] {
  1816. minValueMap[newDate] = handleDataMap[date]
  1817. }
  1818. } else {
  1819. minValueMap[newDate] = handleDataMap[date]
  1820. }
  1821. dataTimeMap[newDate] = newDate
  1822. }
  1823. }
  1824. } else {
  1825. // 如果不跨年 正常获取
  1826. // 获取当前日期所在区间
  1827. // 处理上下限列表
  1828. if value, ok := maxValueMap[newDate]; ok {
  1829. if value < handleDataMap[date] {
  1830. maxValueMap[newDate] = handleDataMap[date]
  1831. }
  1832. } else {
  1833. maxValueMap[newDate] = handleDataMap[date]
  1834. }
  1835. if value, ok := minValueMap[newDate]; ok {
  1836. if value > handleDataMap[date] {
  1837. minValueMap[newDate] = handleDataMap[date]
  1838. }
  1839. } else {
  1840. minValueMap[newDate] = handleDataMap[date]
  1841. }
  1842. dataTimeMap[newDate] = newDate
  1843. }
  1844. }
  1845. } else {
  1846. // 旬度、月度、季度、半年度 不插值,需要先把日期列表和数据map取出来
  1847. for _, vv := range v.DataList {
  1848. dateTime, e := time.Parse(utils.FormatDate, vv.DataTime)
  1849. if e != nil {
  1850. err = errors.New("时间格式化异常, Err:" + e.Error())
  1851. return
  1852. }
  1853. // 不包含当年
  1854. if v.ChartLegend == strconv.Itoa(time.Now().Year()) {
  1855. continue
  1856. }
  1857. if dateTime.Year() < startYear {
  1858. continue
  1859. }
  1860. // 月度的2月29号日期改为2月28日
  1861. if dateTime.Month() == 2 && dateTime.Day() == 29 {
  1862. dateTime = dateTime.AddDate(0, 0, -1)
  1863. }
  1864. newDate = dateTime.AddDate(time.Now().Year()-dateTime.Year(), 0, 0)
  1865. if seasonConfig.JumpYear == 1 {
  1866. if startDate.After(endDate) {
  1867. // 如果跨年且不到一年
  1868. // 全年截取一部分
  1869. if newDate.Before(startDate.AddDate(0, 0, 1)) && newDate.After(endDate) {
  1870. continue
  1871. }
  1872. if newDate.After(startDate.AddDate(0, 0, -1)) {
  1873. // 减一年
  1874. newDate = dateTime.AddDate(time.Now().Year()-dateTime.Year()-1, 0, 0)
  1875. }
  1876. // 处理上下限列表
  1877. if value, ok := maxValueMap[newDate]; ok {
  1878. if value < vv.Value {
  1879. maxValueMap[newDate] = vv.Value
  1880. }
  1881. } else {
  1882. maxValueMap[newDate] = vv.Value
  1883. }
  1884. if value, ok := minValueMap[newDate]; ok {
  1885. if value > vv.Value {
  1886. minValueMap[newDate] = vv.Value
  1887. }
  1888. } else {
  1889. minValueMap[newDate] = vv.Value
  1890. }
  1891. dataTimeMap[newDate] = newDate
  1892. } else {
  1893. // 如果跨年且大于等于一年
  1894. // double后截取
  1895. if newDate.After(startDate) {
  1896. // 处理上下限列表
  1897. if value, ok := maxValueMap[newDate]; ok {
  1898. if value < vv.Value {
  1899. maxValueMap[newDate] = vv.Value
  1900. }
  1901. } else {
  1902. maxValueMap[newDate] = vv.Value
  1903. }
  1904. if value, ok := minValueMap[newDate]; ok {
  1905. if value > vv.Value {
  1906. minValueMap[newDate] = vv.Value
  1907. }
  1908. } else {
  1909. minValueMap[newDate] = vv.Value
  1910. }
  1911. dataTimeMap[newDate] = newDate
  1912. }
  1913. newDate = dateTime.AddDate(time.Now().Year()-dateTime.Year()+1, 0, 0)
  1914. newEndDate := endDate.AddDate(1, 0, 0)
  1915. if newDate.Before(newEndDate) {
  1916. // 处理上下限列表
  1917. if value, ok := maxValueMap[newDate]; ok {
  1918. if value < vv.Value {
  1919. maxValueMap[newDate] = vv.Value
  1920. }
  1921. } else {
  1922. maxValueMap[newDate] = vv.Value
  1923. }
  1924. if value, ok := minValueMap[newDate]; ok {
  1925. if value > vv.Value {
  1926. minValueMap[newDate] = vv.Value
  1927. }
  1928. } else {
  1929. minValueMap[newDate] = vv.Value
  1930. }
  1931. dataTimeMap[newDate] = newDate
  1932. }
  1933. }
  1934. } else {
  1935. // 如果不跨年 正常获取
  1936. // 获取当前日期所在区间
  1937. // 处理上下限列表
  1938. if value, ok := maxValueMap[newDate]; ok {
  1939. if value < vv.Value {
  1940. maxValueMap[newDate] = vv.Value
  1941. }
  1942. } else {
  1943. maxValueMap[newDate] = vv.Value
  1944. }
  1945. if value, ok := minValueMap[newDate]; ok {
  1946. if value > vv.Value {
  1947. minValueMap[newDate] = vv.Value
  1948. }
  1949. } else {
  1950. minValueMap[newDate] = vv.Value
  1951. }
  1952. dataTimeMap[newDate] = newDate
  1953. }
  1954. }
  1955. }
  1956. }
  1957. for _, v := range dataTimeMap {
  1958. maxMinItem := &models.MaxMinLimitsData{}
  1959. if maxValue, ok := maxValueMap[v]; ok {
  1960. maxMinItem.MaxValue = maxValue
  1961. } else {
  1962. maxMinItem.MaxValue = minValueMap[v]
  1963. }
  1964. if minValue, ok := minValueMap[v]; ok {
  1965. maxMinItem.MinValue = minValue
  1966. } else {
  1967. maxMinItem.MinValue = maxValueMap[v]
  1968. }
  1969. maxMinItem.DataTime = v.Format(utils.FormatDate)
  1970. maxMinItem.DataTimestamp = v.UnixNano() / 1e6
  1971. maxMinDataList = append(maxMinDataList, maxMinItem)
  1972. }
  1973. // 排序
  1974. sort.Slice(maxMinDataList, func(i, j int) bool {
  1975. return maxMinDataList[i].DataTime < maxMinDataList[j].DataTime
  1976. })
  1977. dataResp.MaxMinLimits.List = maxMinDataList
  1978. dataResp.MaxMinLimits.Color = seasonConfig.MaxMinLimits.Color
  1979. dataResp.MaxMinLimits.Legend = seasonConfig.MaxMinLimits.Legend
  1980. dataResp.MaxMinLimits.IsShow = seasonConfig.MaxMinLimits.IsShow
  1981. dataResp.MaxMinLimits.IsAdd = seasonConfig.MaxMinLimits.IsAdd
  1982. dataResp.MaxMinLimits.Year = seasonConfig.MaxMinLimits.Year
  1983. }
  1984. // 自定义同期均线
  1985. if seasonConfig.SamePeriodAverage.Year > 0 {
  1986. handleDataMap := make(map[string]float64)
  1987. dataTimeMap := make(map[time.Time]time.Time)
  1988. dataTimeList := make([]string, 0)
  1989. valueMap := make(map[time.Time]float64)
  1990. averageDataList := make([]*models.SamePeriodAverageData, 0)
  1991. for i := len(quarterDataList) - 1; i >= 0; i-- {
  1992. // 插值成日度
  1993. dataTimeList, _, err = HandleDataByLinearRegressionToList(quarterDataList[i].DataList, handleDataMap)
  1994. if err != nil {
  1995. err = errors.New("插值处理数据异常, Err:" + err.Error())
  1996. return
  1997. }
  1998. for _, date := range dataTimeList {
  1999. dateTime, e := time.Parse(utils.FormatDate, date)
  2000. if e != nil {
  2001. err = errors.New("时间格式化异常, Err:" + e.Error())
  2002. return
  2003. }
  2004. startYear := time.Now().AddDate(-seasonConfig.SamePeriodAverage.Year, 0, 0).Year()
  2005. if dateTime.Year() < startYear {
  2006. continue
  2007. }
  2008. // 不包含2月29号
  2009. if dateTime.Month() == 2 && dateTime.Day() == 29 {
  2010. continue
  2011. }
  2012. // 不包含当年
  2013. if quarterDataList[i].ChartLegend == strconv.Itoa(time.Now().Year()) {
  2014. continue
  2015. }
  2016. newDate := dateTime.AddDate(time.Now().Year()-dateTime.Year(), 0, 0)
  2017. // 处理均值
  2018. if value, ok := valueMap[newDate]; ok {
  2019. valueMap[newDate] = (handleDataMap[date] + value) / 2
  2020. } else {
  2021. valueMap[newDate] = handleDataMap[date]
  2022. }
  2023. dataTimeMap[newDate] = newDate
  2024. }
  2025. }
  2026. for _, v := range dataTimeMap {
  2027. averageItem := &models.SamePeriodAverageData{}
  2028. if value, ok := valueMap[v]; ok {
  2029. averageItem.Value = value
  2030. }
  2031. averageItem.DataTime = v.Format(utils.FormatDate)
  2032. averageItem.DataTimestamp = v.UnixNano() / 1e6
  2033. averageDataList = append(averageDataList, averageItem)
  2034. }
  2035. // 排序
  2036. sort.Slice(averageDataList, func(i, j int) bool {
  2037. return averageDataList[i].DataTime < averageDataList[j].DataTime
  2038. })
  2039. dataResp.SamePeriodAverage.List = averageDataList
  2040. dataResp.SamePeriodAverage.Year = seasonConfig.SamePeriodAverage.Year
  2041. dataResp.SamePeriodAverage.Color = seasonConfig.SamePeriodAverage.Color
  2042. dataResp.SamePeriodAverage.Legend = seasonConfig.SamePeriodAverage.Legend
  2043. dataResp.SamePeriodAverage.IsShow = seasonConfig.SamePeriodAverage.IsShow
  2044. dataResp.SamePeriodAverage.LineType = seasonConfig.SamePeriodAverage.LineType
  2045. dataResp.SamePeriodAverage.LineWidth = seasonConfig.SamePeriodAverage.LineWidth
  2046. dataResp.SamePeriodAverage.IsAdd = seasonConfig.SamePeriodAverage.IsAdd
  2047. }
  2048. // 自定义同期标准差
  2049. if seasonConfig.SamePeriodStandardDeviation.Year > 1 && seasonConfig.SamePeriodStandardDeviation.Multiple > 0 {
  2050. startYear := time.Now().AddDate(-seasonConfig.SamePeriodStandardDeviation.Year, 0, 0).Year()
  2051. // 先算均值,再算标准差
  2052. handleDataMap := make(map[string]float64)
  2053. dataTimeMap := make(map[time.Time]time.Time)
  2054. dataTimeValueMap := make(map[time.Time][]float64)
  2055. dataTimeList := make([]string, 0)
  2056. valueMap := make(map[time.Time]float64)
  2057. samePeriodStandardDeviationList := make([]*models.MaxMinLimitsData, 0)
  2058. for i := len(quarterDataList) - 1; i > len(quarterDataList)-seasonConfig.SamePeriodAverage.Year-1 && i > 0; i-- {
  2059. // 插值成日度
  2060. dataTimeList, _, err = HandleDataByLinearRegressionToListV2(quarterDataList[i].DataList, handleDataMap)
  2061. if err != nil {
  2062. err = errors.New("插值处理数据异常, Err:" + err.Error())
  2063. return
  2064. }
  2065. for _, date := range dataTimeList {
  2066. dateTime, e := time.Parse(utils.FormatDate, date)
  2067. if e != nil {
  2068. err = errors.New("时间格式化异常, Err:" + e.Error())
  2069. return
  2070. }
  2071. if dateTime.Year() < startYear {
  2072. continue
  2073. }
  2074. // 不包含2月29号
  2075. if dateTime.Month() == 2 && dateTime.Day() == 29 {
  2076. continue
  2077. }
  2078. newDate := dateTime.AddDate(time.Now().Year()-dateTime.Year(), 0, 0)
  2079. // 处理均值
  2080. if value, ok := valueMap[newDate]; ok {
  2081. valueMap[newDate] = (handleDataMap[date] + value) / 2
  2082. } else {
  2083. valueMap[newDate] = handleDataMap[date]
  2084. }
  2085. dataTimeMap[newDate] = newDate
  2086. valueList := dataTimeValueMap[newDate]
  2087. valueList = append(valueList, handleDataMap[date])
  2088. dataTimeValueMap[newDate] = valueList
  2089. }
  2090. }
  2091. for _, v := range dataTimeMap {
  2092. valueList := dataTimeValueMap[v]
  2093. stdev := utils.CalculateStandardDeviation(valueList)
  2094. stdev, _ = decimal.NewFromFloat(stdev).Round(4).Float64()
  2095. maxMinItem := &models.MaxMinLimitsData{}
  2096. if value, ok := valueMap[v]; ok {
  2097. maxMinItem.MaxValue = value + stdev*seasonConfig.SamePeriodStandardDeviation.Multiple
  2098. maxMinItem.MinValue = value - stdev*seasonConfig.SamePeriodStandardDeviation.Multiple
  2099. }
  2100. maxMinItem.DataTime = v.Format(utils.FormatDate)
  2101. maxMinItem.DataTimestamp = v.UnixNano() / 1e6
  2102. samePeriodStandardDeviationList = append(samePeriodStandardDeviationList, maxMinItem)
  2103. }
  2104. // 排序
  2105. sort.Slice(samePeriodStandardDeviationList, func(i, j int) bool {
  2106. return samePeriodStandardDeviationList[i].DataTime < samePeriodStandardDeviationList[j].DataTime
  2107. })
  2108. dataResp.SamePeriodStandardDeviation.List = samePeriodStandardDeviationList
  2109. dataResp.SamePeriodStandardDeviation.Color = seasonConfig.SamePeriodStandardDeviation.Color
  2110. dataResp.SamePeriodStandardDeviation.Legend = seasonConfig.SamePeriodStandardDeviation.Legend
  2111. dataResp.SamePeriodStandardDeviation.IsShow = seasonConfig.SamePeriodStandardDeviation.IsShow
  2112. dataResp.SamePeriodStandardDeviation.Multiple = seasonConfig.SamePeriodStandardDeviation.Multiple
  2113. dataResp.SamePeriodStandardDeviation.Year = seasonConfig.SamePeriodStandardDeviation.Year
  2114. dataResp.SamePeriodStandardDeviation.IsAdd = seasonConfig.SamePeriodStandardDeviation.IsAdd
  2115. }
  2116. // 自定义右轴
  2117. if seasonConfig.RightAxis.IndicatorType != 0 {
  2118. if seasonConfig.RightAxis.IndicatorType == 1 {
  2119. startTime, _ := time.Parse(utils.FormatDate, mappingItem.StartDate)
  2120. for i := len(quarterDataList) - 1; i > len(quarterDataList)-2 && i > 0; i-- {
  2121. var rightMappingItem models.ChartEdbInfoMapping
  2122. rightMappingItem = *mappingItem
  2123. // 计算同比值
  2124. tbzDataList, minValue, maxValue, e := GetEdbDataTbzForSeason(mappingItem.Frequency, quarterDataList[i].DataList, startTime)
  2125. if e != nil {
  2126. err = errors.New("计算同比值失败, Err:" + e.Error())
  2127. return
  2128. }
  2129. rightMappingItem.DataList = tbzDataList
  2130. rightMappingItem.MaxData = maxValue
  2131. rightMappingItem.MinData = minValue
  2132. dataResp.RightAxis.EdbInfoList = append(dataResp.RightAxis.EdbInfoList, &rightMappingItem)
  2133. }
  2134. }
  2135. dataResp.RightAxis.SeasonRightAxis = seasonConfig.RightAxis
  2136. }
  2137. }
  2138. return
  2139. }
  2140. // GetChartDetailDataByChartInfoId 根据图表信息id获取图表详情数据
  2141. func GetChartDetailDataByChartInfoId(chartInfo *models.ChartInfoView, isCache bool) (resp *models.ChartInfoDetailResp, err error, errMsg string) {
  2142. // 添加至缓存中
  2143. //是否走缓存
  2144. chartInfoId := chartInfo.ChartInfoId
  2145. resp = new(models.ChartInfoDetailResp)
  2146. //判断是否存在缓存,如果存在缓存,那么直接从缓存中获取
  2147. key := fmt.Sprint(utils.CACHE_CHART_INFO_DATA, chartInfo.ChartInfoId)
  2148. if utils.Re == nil && isCache {
  2149. if utils.Re == nil && utils.Rc.IsExist(key) {
  2150. if chartData, err1 := utils.Rc.RedisBytes(key); err1 == nil {
  2151. err = json.Unmarshal(chartData, &resp)
  2152. if err != nil || resp == nil {
  2153. return
  2154. }
  2155. return
  2156. }
  2157. }
  2158. }
  2159. chartType := chartInfo.ChartType
  2160. startDate := chartInfo.StartDate
  2161. endDate := chartInfo.EndDate
  2162. seasonStartDate := chartInfo.SeasonStartDate
  2163. seasonEndDate := chartInfo.SeasonEndDate
  2164. startYear := chartInfo.StartYear
  2165. calendar := chartInfo.Calendar
  2166. dateType := chartInfo.DateType
  2167. // 获取主题样式
  2168. chartTheme, err := GetChartThemeConfig(chartInfo.ChartThemeId, chartInfo.Source, chartInfo.ChartType)
  2169. if err != nil {
  2170. errMsg = "获取失败"
  2171. err = fmt.Errorf("获取主题信息失败,Err:" + err.Error())
  2172. return
  2173. }
  2174. chartInfo.ChartThemeStyle = chartTheme.Config
  2175. chartInfo.ChartThemeId = chartTheme.ChartThemeId
  2176. mappingList := make([]*models.ChartEdbInfoMapping, 0)
  2177. mappingList, err = models.GetChartEdbMappingList(chartInfoId)
  2178. if err != nil {
  2179. errMsg = "获取失败"
  2180. err = fmt.Errorf("获取图表,指标信息失败,Err:" + err.Error())
  2181. return
  2182. }
  2183. // 图表额外数据参数
  2184. extraConfigStr := chartInfo.ExtraConfig
  2185. // 柱方图的一些配置
  2186. var barConfig models.BarChartInfoReq
  2187. if chartInfo != nil && chartInfo.ChartType == 7 {
  2188. if chartInfo.BarConfig == `` {
  2189. errMsg = "柱方图未配置"
  2190. err = fmt.Errorf("柱方图未配置")
  2191. return
  2192. }
  2193. err = json.Unmarshal([]byte(chartInfo.BarConfig), &barConfig)
  2194. if err != nil {
  2195. errMsg = "柱方图配置异常"
  2196. err = fmt.Errorf("柱方图配置异常")
  2197. return
  2198. }
  2199. extraConfigStr = chartInfo.BarConfig
  2200. }
  2201. if chartType == 2 {
  2202. startDate = seasonStartDate
  2203. endDate = seasonEndDate
  2204. if dateType <= 0 {
  2205. if startDate != "" {
  2206. dateType = 5
  2207. } else {
  2208. dateType = utils.DateTypeNYears
  2209. }
  2210. }
  2211. } else {
  2212. if dateType <= 0 {
  2213. dateType = 3
  2214. }
  2215. }
  2216. yearMax := 0
  2217. if dateType == utils.DateTypeNYears {
  2218. for _, v := range mappingList {
  2219. if v.LatestDate != "" {
  2220. lastDateT, tErr := time.Parse(utils.FormatDate, v.LatestDate)
  2221. if tErr != nil {
  2222. errMsg = "获取失败"
  2223. err = fmt.Errorf("获取图表日期信息失败,Err:" + tErr.Error())
  2224. return
  2225. }
  2226. if lastDateT.Year() > yearMax {
  2227. yearMax = lastDateT.Year()
  2228. }
  2229. }
  2230. }
  2231. }
  2232. startDate, endDate = utils.GetDateByDateTypeV2(dateType, startDate, endDate, startYear, yearMax)
  2233. if chartInfo.ChartType == 2 {
  2234. chartInfo.StartDate = startDate
  2235. chartInfo.EndDate = endDate
  2236. chartInfo.Calendar = calendar
  2237. }
  2238. // 获取图表中的指标数据
  2239. edbList, xEdbIdValue, yDataList, dataResp, err, errMsg := GetChartEdbData(chartInfoId, chartType, calendar, startDate, endDate, mappingList, extraConfigStr, chartInfo.SeasonExtraConfig)
  2240. if err != nil {
  2241. if errMsg == `` {
  2242. errMsg = "获取失败"
  2243. }
  2244. err = fmt.Errorf("获取图表,指标信息失败,Err:" + err.Error())
  2245. return
  2246. }
  2247. // 单位
  2248. if chartType == utils.CHART_TYPE_BAR && len(yDataList) > 0 {
  2249. chartInfo.Unit = yDataList[0].Unit
  2250. chartInfo.UnitEn = yDataList[0].UnitEn
  2251. }
  2252. warnEdbList := make([]string, 0)
  2253. for _, v := range edbList {
  2254. if v.IsNullData {
  2255. warnEdbList = append(warnEdbList, v.EdbName+"("+v.EdbCode+")")
  2256. }
  2257. }
  2258. if len(warnEdbList) > 0 {
  2259. chartInfo.WarnMsg = `图表引用指标异常,异常指标:` + strings.Join(warnEdbList, ",")
  2260. }
  2261. // 图表的指标来源
  2262. sourceNameList, sourceNameEnList := GetEdbSourceByEdbInfoIdList(edbList)
  2263. chartInfo.ChartSource = strings.Join(sourceNameList, ",")
  2264. chartInfo.ChartSourceEn = strings.Join(sourceNameEnList, ",")
  2265. //判断是否需要展示英文标识
  2266. chartInfo.IsEnChart = CheckIsEnChart(chartInfo.ChartNameEn, edbList, chartInfo.Source, chartInfo.ChartType)
  2267. resp.EdbInfoList = edbList
  2268. resp.XEdbIdValue = xEdbIdValue
  2269. resp.YDataList = yDataList
  2270. resp.DataResp = dataResp
  2271. chartInfo.Button = models.ChartViewButton{
  2272. IsEdit: chartInfo.IsEdit,
  2273. IsEnChart: chartInfo.IsEnChart,
  2274. IsAdd: chartInfo.IsAdd,
  2275. IsCopy: true,
  2276. IsSetName: chartInfo.IsSetName,
  2277. }
  2278. resp.ChartInfo = chartInfo
  2279. // 将数据加入缓存
  2280. if utils.Re == nil {
  2281. d, _ := json.Marshal(resp)
  2282. _ = utils.Rc.Put(key, d, 2*time.Hour)
  2283. }
  2284. return
  2285. }