chart_info_excel_balance.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684
  1. package data
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "eta/eta_api/models/data_manage"
  6. excelModel "eta/eta_api/models/data_manage/excel"
  7. "eta/eta_api/models/data_manage/excel/request"
  8. "eta/eta_api/models/system"
  9. "eta/eta_api/utils"
  10. "fmt"
  11. "math"
  12. "strconv"
  13. "strings"
  14. "time"
  15. )
  16. // AddBalanceExcelChart 添加平衡表图表
  17. func AddBalanceExcelChart(req request.AddBalanceTableChartReq, sysUser *system.Admin) (chartInfo *data_manage.ChartInfo, err error, errMsg string, isSendEmail bool) {
  18. // 获取表格信息
  19. excelInfo, err := excelModel.GetExcelInfoById(req.ExcelInfoId)
  20. if err != nil {
  21. errMsg = "找不到该EXCEL"
  22. err = fmt.Errorf("找不到该EXCEL!%s", err.Error())
  23. return
  24. }
  25. if excelInfo.Source != utils.BALANCE_TABLE {
  26. errMsg = "EXCEL类型错误!"
  27. err = fmt.Errorf("EXCEL类型错误!")
  28. return
  29. }
  30. if len(req.ChartEdbInfoList) == 0 {
  31. errMsg = "图表数据不能为空!"
  32. err = fmt.Errorf("图表数据不能为空!%s", err.Error())
  33. return
  34. }
  35. chartEdbList := make([]*excelModel.AddChartEdbAndDataItem, 0)
  36. for _, chartEdb := range req.ChartEdbInfoList {
  37. excelEdb := new(excelModel.ExcelChartEdb)
  38. excelEdb.EdbName = chartEdb.EdbName
  39. randStr := utils.GetRandDigit(4)
  40. excelEdb.EdbCode = `T` + time.Now().Format("060102150405") + "_" + randStr
  41. excelEdb.ExcelInfoId = excelInfo.ExcelInfoId
  42. excelEdb.DateSequence = chartEdb.DateSequenceStr
  43. excelEdb.DataSequence = chartEdb.DataSequenceStr
  44. excelEdb.SysUserId = sysUser.AdminId
  45. excelEdb.SysUserRealName = sysUser.RealName
  46. excelEdb.MaxData = chartEdb.MaxData
  47. excelEdb.MinData = chartEdb.MinData
  48. excelEdb.IsOrder = chartEdb.IsOrder
  49. excelEdb.IsAxis = chartEdb.IsAxis
  50. excelEdb.FromTag = chartEdb.FromTag
  51. excelEdb.EdbInfoType = chartEdb.EdbInfoType
  52. excelEdb.LeadValue = chartEdb.LeadValue
  53. excelEdb.LeadUnit = chartEdb.LeadUnit
  54. excelEdb.CreateTime = time.Now()
  55. excelEdb.ModifyTime = time.Now()
  56. var dateList []string
  57. var dataList []float64
  58. if excelInfo.BalanceType == 1 {
  59. // 如果是静态表,则直接使用前端传输的数据落到数据库里
  60. /*dateList, dataList, err, errMsg = utils.HandleEdbSequenceVal(chartEdb.DateSequenceVal, chartEdb.DataSequenceVal)
  61. if err != nil {
  62. errMsg = "时间序列或数据序列异常!"
  63. err = fmt.Errorf("时间序列或数据序列异常!%s", err.Error())
  64. return
  65. }*/
  66. }
  67. // 处理日期列表和值列表
  68. addItem := &excelModel.AddChartEdbAndDataItem{
  69. ChartEdb: excelEdb,
  70. DateList: dateList,
  71. ValList: dataList,
  72. }
  73. chartEdbList = append(chartEdbList, addItem)
  74. }
  75. chartInfo, err, errMsg, isSendEmail = addBalanceExcelChart(req, sysUser.AdminId, sysUser.RealName)
  76. if err != nil {
  77. errMsg = "新增图表失败!"
  78. err = fmt.Errorf("新增图表失败!%s, %s", errMsg, err.Error())
  79. return
  80. }
  81. obj := new(excelModel.ExcelChartEdb)
  82. err = obj.AddChartEdbAndData(chartEdbList, chartInfo)
  83. if err != nil {
  84. errMsg = "新增图表失败!"
  85. err = fmt.Errorf("新增图表数据失败!%s", err.Error())
  86. return
  87. }
  88. return
  89. }
  90. func addBalanceExcelChart(req request.AddBalanceTableChartReq, sysUserId int, sysUserRealName string) (chartInfo *data_manage.ChartInfo, err error, errMsg string, isSendEmail bool) {
  91. isSendEmail = true // 默认错误的时候要发送邮件
  92. req.ChartName = strings.Trim(req.ChartName, " ")
  93. if req.ChartName == "" {
  94. errMsg = "请填写图表名称!"
  95. err = fmt.Errorf(errMsg)
  96. isSendEmail = false
  97. return
  98. }
  99. chartType := req.ChartType
  100. extraConfig := req.ExtraConfig
  101. // todo 查找默认主题设置
  102. // 季节性图表额外配置信息
  103. var seasonExtraConfig string
  104. if len(req.ChartEdbInfoList) <= 0 {
  105. errMsg = "请选择指标!"
  106. err = fmt.Errorf(errMsg)
  107. return
  108. }
  109. if chartType == 2 {
  110. // 处理季节性图表横轴配置
  111. {
  112. if req.SeasonExtraConfig.XEndDate != "" {
  113. if req.SeasonExtraConfig.XStartDate > req.SeasonExtraConfig.XEndDate && req.SeasonExtraConfig.JumpYear != 1 {
  114. errMsg = "季节性图表配置信息异常:横坐标日期配置错误"
  115. err = fmt.Errorf("季节性图表配置信息异常: 横坐标日期配置错误")
  116. return
  117. }
  118. seasonExtra, tErr := json.Marshal(req.SeasonExtraConfig)
  119. if tErr != nil {
  120. errMsg = "季节性图表配置信息异常"
  121. err = fmt.Errorf("季节性图表配置信息异常,Err:" + tErr.Error())
  122. return
  123. }
  124. seasonExtraConfig = string(seasonExtra)
  125. }
  126. }
  127. }
  128. // 图表额外配置
  129. extraConfig, err, errMsg = HandleExtraConfig(chartType, extraConfig)
  130. if err != nil {
  131. if errMsg == `` {
  132. errMsg = "指标异常!"
  133. }
  134. err = fmt.Errorf("指标异常!Err:" + err.Error())
  135. return
  136. }
  137. //判断图表是否存在
  138. var condition string
  139. var pars []interface{}
  140. // 图表名称在不同图分类下不允许重复 需求调整时间:2022年11月07日09:47:07
  141. condition += " AND chart_classify_id=0 "
  142. condition += " AND chart_name=? AND source = ? "
  143. pars = append(pars, req.ChartName, utils.CHART_SOURCE_BALANCE_EXCEL)
  144. count, err := data_manage.GetChartInfoCountByCondition(condition, pars)
  145. if err != nil {
  146. errMsg = "判断图表名称是否存在失败"
  147. err = fmt.Errorf("判断图表名称是否存在失败,Err:" + err.Error())
  148. return
  149. }
  150. if count > 0 {
  151. errMsg = "图表已存在,请重新填写"
  152. err = fmt.Errorf("判断图表名称是否存在失败")
  153. isSendEmail = false
  154. return
  155. }
  156. // todo 判断是否是禁用的图表
  157. // disableVal := data.CheckIsDisableChart(edbInfoIdArr)
  158. chartInfo = new(data_manage.ChartInfo)
  159. chartInfo.ChartName = req.ChartName
  160. //chartInfo.EdbInfoIds = edbInfoIdStr
  161. //chartInfo.ChartClassifyId = req.ChartClassifyId
  162. chartInfo.SysUserId = sysUserId
  163. chartInfo.SysUserRealName = sysUserRealName
  164. chartInfo.CreateTime = time.Now()
  165. chartInfo.ModifyTime = time.Now()
  166. chartInfo.IsSetName = 0
  167. timestamp := strconv.FormatInt(time.Now().UnixNano(), 10)
  168. chartInfo.UniqueCode = utils.MD5(utils.CHART_PREFIX + "_" + timestamp)
  169. // todo 判断是否需要重新计算用户的start_date
  170. chartInfo.DateType = 3
  171. if chartType == 0 {
  172. chartType = 1
  173. }
  174. chartInfo.ChartType = chartType
  175. calendar := req.Calendar
  176. if calendar == "" {
  177. calendar = "公历"
  178. }
  179. chartInfo.Calendar = calendar
  180. /* chartInfo.StartDate = req.StartDate
  181. chartInfo.EndDate = req.EndDate
  182. chartInfo.SeasonStartDate = req.StartDate
  183. chartInfo.SeasonEndDate = req.EndDate*/
  184. chartInfo.LeftMin = req.LeftMin
  185. chartInfo.LeftMax = req.LeftMax
  186. chartInfo.RightMin = req.RightMin
  187. chartInfo.RightMax = req.RightMax
  188. chartInfo.Right2Min = req.Right2Min
  189. chartInfo.Right2Max = req.Right2Max
  190. chartInfo.MinMaxSave = req.MinMaxSave
  191. //chartInfo.Disabled = disableVal
  192. //chartInfo.BarConfig = barChartConf
  193. chartInfo.ExtraConfig = extraConfig
  194. chartInfo.SeasonExtraConfig = seasonExtraConfig
  195. //chartInfo.StartYear = req.StartYear
  196. chartInfo.Source = utils.CHART_SOURCE_BALANCE_EXCEL
  197. // chartInfo.ChartThemeId = req.ChartThemeId
  198. chartInfo.SourcesFrom = req.SourcesFrom
  199. /* chartInfo.Instructions = req.Instructions
  200. chartInfo.MarkersLines = req.MarkersLines
  201. chartInfo.MarkersAreas = req.MarkersAreas
  202. chartInfo.Unit = req.Unit
  203. chartInfo.UnitEn = req.UnitEn*/
  204. /*newId, err := data_manage.AddChartInfo(chartInfo)
  205. if err != nil {
  206. errMsg = `保存失败`
  207. err = fmt.Errorf("保存失败,Err:" + err.Error())
  208. return
  209. }
  210. chartInfo.ChartInfoId = int(newId)*/
  211. //添加es数据
  212. //go EsAddOrEditChartInfo(chartInfo.ChartInfoId)
  213. return
  214. }
  215. func GetBalanceExcelChartDetail(chartInfo *data_manage.ChartInfoView, mappingListTmp []*excelModel.ExcelChartEdb, sysUser *system.Admin, dataListMap map[int][]*data_manage.EdbDataList) (resp *data_manage.ChartInfoDetailResp, err error, errMsg string) {
  216. // todo 图表权限处理
  217. chartInfoId := chartInfo.ChartInfoId
  218. resp = new(data_manage.ChartInfoDetailResp)
  219. // 获取主题样式
  220. chartTheme, err := GetChartThemeConfig(chartInfo.ChartThemeId, chartInfo.Source, chartInfo.ChartType)
  221. if err != nil {
  222. errMsg = "获取失败"
  223. err = fmt.Errorf(" 获取主题信息失败 Err:%s", err.Error())
  224. return
  225. }
  226. chartInfo.ChartThemeStyle = chartTheme.Config
  227. chartInfo.ChartThemeId = chartTheme.ChartThemeId
  228. dateType := chartInfo.DateType
  229. fmt.Println("dateType:", dateType)
  230. chartType := chartInfo.ChartType
  231. startDate := chartInfo.StartDate
  232. endDate := chartInfo.EndDate
  233. seasonStartDate := chartInfo.SeasonStartDate
  234. seasonEndDate := chartInfo.SeasonEndDate
  235. //startYear := chartInfo.StartYear
  236. calendar := chartInfo.Calendar
  237. if calendar == "" {
  238. calendar = "公历"
  239. }
  240. mappingList := make([]*data_manage.ChartEdbInfoMapping, 0)
  241. //循环组装映射关系
  242. for _, v := range mappingListTmp {
  243. mapping := &data_manage.ChartEdbInfoMapping{
  244. EdbInfoId: v.ExcelChartEdbId,
  245. SourceName: "",
  246. Source: 0,
  247. SubSource: 0,
  248. EdbCode: v.EdbCode,
  249. EdbName: v.EdbName,
  250. EdbAliasName: v.EdbName,
  251. EdbNameEn: "",
  252. EdbAliasNameEn: "",
  253. EdbType: 0,
  254. Frequency: "",
  255. FrequencyEn: "",
  256. Unit: "",
  257. UnitEn: "",
  258. StartDate: "",
  259. EndDate: "",
  260. ModifyTime: v.ModifyTime.Format(utils.FormatDateTime),
  261. ChartEdbMappingId: v.ExcelChartEdbId,
  262. ChartInfoId: chartInfoId,
  263. MaxData: v.MaxData,
  264. MinData: v.MinData,
  265. IsOrder: v.IsOrder,
  266. IsAxis: v.IsAxis,
  267. //EdbInfoType: 0,
  268. //EdbInfoCategoryType: 0,
  269. LeadValue: v.LeadValue,
  270. LeadUnit: v.LeadUnit,
  271. LeadUnitEn: "",
  272. ChartStyle: "",
  273. ChartColor: "",
  274. PredictChartColor: "",
  275. ChartWidth: 0,
  276. ChartType: 0,
  277. LatestDate: "",
  278. LatestValue: 0,
  279. MoveLatestDate: "",
  280. UniqueCode: "",
  281. MinValue: 0,
  282. MaxValue: 0,
  283. DataList: nil,
  284. IsNullData: false,
  285. MappingSource: 0,
  286. RegionType: "",
  287. ClassifyId: 0,
  288. IsConvert: 0,
  289. ConvertType: 0,
  290. ConvertValue: 0,
  291. ConvertUnit: "",
  292. ConvertEnUnit: "",
  293. IsJoinPermission: 0,
  294. HaveOperaAuth: true,
  295. }
  296. mappingList = append(mappingList, mapping)
  297. }
  298. if chartType == 2 {
  299. startDate = seasonStartDate
  300. endDate = seasonEndDate
  301. if dateType <= 0 {
  302. if startDate != "" {
  303. dateType = 5
  304. } else {
  305. dateType = utils.DateTypeNYears
  306. }
  307. }
  308. } else {
  309. if dateType <= 0 {
  310. dateType = 3
  311. }
  312. }
  313. /*yearMax := 0
  314. if dateType == utils.DateTypeNYears {
  315. for _, v := range mappingList {
  316. if v.LatestDate != "" {
  317. lastDateT, tErr := time.Parse(utils.FormatDate, v.LatestDate)
  318. if tErr != nil {
  319. br.Msg = "获取失败"
  320. br.ErrMsg = "获取图表日期信息失败,Err:" + tErr.Error()
  321. return
  322. }
  323. if lastDateT.Year() > yearMax {
  324. yearMax = lastDateT.Year()
  325. }
  326. }
  327. }
  328. }
  329. startDate, endDate = utils.GetDateByDateTypeV2(dateType, startDate, endDate, startYear, yearMax)*/
  330. if chartInfo.ChartType == 2 {
  331. chartInfo.StartDate = startDate
  332. chartInfo.EndDate = endDate
  333. }
  334. // 图表额外数据参数
  335. extraConfigStr := chartInfo.ExtraConfig
  336. // 柱方图的一些配置
  337. var barConfig data_manage.BarChartInfoReq
  338. if chartInfo != nil && chartInfo.ChartType == 7 {
  339. if chartInfo.BarConfig == `` {
  340. err = fmt.Errorf("柱方图未配置")
  341. errMsg = "柱方图未配置"
  342. return
  343. }
  344. err = json.Unmarshal([]byte(chartInfo.BarConfig), &barConfig)
  345. if err != nil {
  346. err = fmt.Errorf("柱方图配置异常 json.Unmarshal Err:%s", err.Error())
  347. errMsg = "柱方图配置异常"
  348. return
  349. }
  350. extraConfigStr = chartInfo.BarConfig
  351. }
  352. // 获取表格数据
  353. excelChartInfoDataShow := new(ExcelChartInfoDataShow)
  354. excelChartInfoDataShow.DataListMap = dataListMap
  355. if chartInfo.HaveOperaAuth || true {
  356. // 获取图表中的指标数据
  357. edbList, xEdbIdValue, yDataList, dataResp, e, msg := GetChartEdbDataV2(chartInfoId, chartType, calendar, startDate, endDate, mappingList, extraConfigStr, chartInfo.SeasonExtraConfig, excelChartInfoDataShow)
  358. if e != nil {
  359. err = fmt.Errorf("获取图表,指标数据失败,Err:%s", e.Error())
  360. errMsg = msg
  361. return
  362. }
  363. // 单位
  364. if chartType == utils.CHART_TYPE_BAR && len(yDataList) > 0 {
  365. chartInfo.Unit = yDataList[0].Unit
  366. chartInfo.UnitEn = yDataList[0].UnitEn
  367. }
  368. warnEdbList := make([]string, 0)
  369. for _, v := range edbList {
  370. if v.IsNullData {
  371. warnEdbList = append(warnEdbList, v.EdbName+"("+v.EdbCode+")")
  372. }
  373. }
  374. if len(warnEdbList) > 0 {
  375. chartInfo.WarnMsg = `图表引用指标异常,异常指标:` + strings.Join(warnEdbList, ",")
  376. }
  377. if chartInfoId > 0 && chartInfo != nil {
  378. //判断是否加入我的图库
  379. {
  380. var myChartCondition string
  381. var myChartPars []interface{}
  382. myChartCondition += ` AND a.admin_id=? `
  383. myChartPars = append(myChartPars, sysUser.AdminId)
  384. myChartCondition += ` AND a.chart_info_id=? `
  385. myChartPars = append(myChartPars, chartInfo.ChartInfoId)
  386. myChartList, e := data_manage.GetMyChartByCondition(myChartCondition, myChartPars)
  387. if e != nil && e.Error() != utils.ErrNoRow() {
  388. errMsg = "获取失败"
  389. err = fmt.Errorf("获取我的图表信息失败,GetMyChartByCondition,Err:" + e.Error())
  390. return
  391. }
  392. if myChartList != nil && len(myChartList) > 0 {
  393. chartInfo.IsAdd = true
  394. chartInfo.MyChartId = myChartList[0].MyChartId
  395. chartInfo.MyChartClassifyId = myChartList[0].MyChartClassifyId
  396. }
  397. }
  398. }
  399. //判断是否需要展示英文标识
  400. chartInfo.IsEnChart = CheckIsEnChart(chartInfo.ChartNameEn, edbList, chartInfo.Source, chartInfo.ChartType)
  401. // 图表的指标来源
  402. sourceNameList, sourceNameEnList := GetEdbSourceByEdbInfoIdList(edbList)
  403. chartInfo.ChartSource = strings.Join(sourceNameList, ",")
  404. chartInfo.ChartSourceEn = strings.Join(sourceNameEnList, ",")
  405. // todo 指标权限
  406. {
  407. for _, item := range edbList {
  408. // 数据权限
  409. item.HaveOperaAuth = true
  410. }
  411. }
  412. resp.EdbInfoList = edbList
  413. resp.XEdbIdValue = xEdbIdValue
  414. resp.YDataList = yDataList
  415. resp.DataResp = dataResp
  416. } else {
  417. resp.EdbInfoList = mappingList
  418. }
  419. //图表操作权限
  420. chartInfo.IsEdit = CheckOpChartPermission(sysUser, chartInfo.SysUserId, chartInfo.HaveOperaAuth)
  421. chartInfo.Button = data_manage.ChartViewButton{
  422. IsEdit: chartInfo.IsEdit,
  423. IsEnChart: chartInfo.IsEnChart,
  424. IsAdd: chartInfo.IsAdd,
  425. IsCopy: true,
  426. IsSetName: chartInfo.IsSetName,
  427. }
  428. resp.ChartInfo = chartInfo
  429. resp.BarChartInfo = barConfig
  430. return
  431. }
  432. // GetBalanceExcelEdbDataMapList 获取指标最后的基础数据
  433. func GetBalanceExcelEdbDataMapList(chartInfoId, chartType int, calendar, startDate, endDate string, mappingList []*data_manage.ChartEdbInfoMapping, seasonExtraConfig string, dataListMap map[int][]*data_manage.EdbDataList) (edbDataListMap map[int][]*data_manage.EdbDataList, edbList []*data_manage.ChartEdbInfoMapping, err error) {
  434. // 指标对应的所有数据
  435. edbDataListMap = make(map[int][]*data_manage.EdbDataList)
  436. for _, v := range mappingList {
  437. //fmt.Println("v:", v.EdbInfoId)
  438. item := new(data_manage.ChartEdbInfoMapping)
  439. item.EdbInfoId = v.EdbInfoId
  440. item.SourceName = v.SourceName
  441. item.Source = v.Source
  442. item.EdbCode = v.EdbCode
  443. item.EdbName = v.EdbName
  444. item.EdbNameEn = v.EdbNameEn
  445. item.Frequency = v.Frequency
  446. item.EdbType = v.EdbType
  447. item.FrequencyEn = GetFrequencyEn(v.Frequency)
  448. if v.Unit != `无` {
  449. item.Unit = v.Unit
  450. }
  451. item.UnitEn = v.UnitEn
  452. item.StartDate = v.StartDate
  453. item.EndDate = v.EndDate
  454. item.ModifyTime = v.ModifyTime
  455. item.EdbInfoCategoryType = v.EdbInfoCategoryType
  456. item.PredictChartColor = v.PredictChartColor
  457. item.ClassifyId = v.ClassifyId
  458. if chartInfoId <= 0 {
  459. item.IsAxis = 1
  460. item.LeadValue = 0
  461. item.LeadUnit = ""
  462. item.ChartEdbMappingId = 0
  463. item.ChartInfoId = 0
  464. item.IsOrder = false
  465. item.EdbInfoType = 1
  466. item.ChartStyle = ""
  467. item.ChartColor = ""
  468. item.ChartWidth = 0
  469. item.MaxData = v.MaxValue
  470. item.MinData = v.MinValue
  471. } else {
  472. item.IsAxis = v.IsAxis
  473. item.EdbInfoType = v.EdbInfoType
  474. item.LeadValue = v.LeadValue
  475. item.LeadUnit = v.LeadUnit
  476. item.LeadUnitEn = GetLeadUnitEn(v.LeadUnit)
  477. item.ChartEdbMappingId = v.ChartEdbMappingId
  478. item.ChartInfoId = v.ChartInfoId
  479. item.ChartStyle = v.ChartStyle
  480. item.ChartColor = v.ChartColor
  481. item.ChartWidth = v.ChartWidth
  482. item.IsOrder = v.IsOrder
  483. item.MaxData = v.MaxData
  484. item.MinData = v.MinData
  485. }
  486. item.LatestValue = v.LatestValue
  487. item.LatestDate = v.LatestDate
  488. item.UniqueCode = v.UniqueCode
  489. item.MoveLatestDate = v.LatestDate
  490. item.EdbAliasName = v.EdbAliasName
  491. item.IsConvert = v.IsConvert
  492. item.ConvertType = v.ConvertType
  493. item.ConvertValue = v.ConvertValue
  494. item.ConvertUnit = v.ConvertUnit
  495. item.ConvertEnUnit = v.ConvertEnUnit
  496. item.IsJoinPermission = v.IsJoinPermission
  497. var startDateReal string
  498. var diffSeconds int64
  499. if chartType == 2 { //季节性图
  500. startDateReal = startDate
  501. } else {
  502. if v.EdbInfoType == 0 && v.LeadUnit != "" && v.LeadValue > 0 { //领先指标
  503. var startTimeRealTemp time.Time
  504. startDateParse, _ := time.Parse(utils.FormatDate, startDate)
  505. switch v.LeadUnit {
  506. case "天":
  507. startTimeRealTemp = startDateParse.AddDate(0, 0, -v.LeadValue)
  508. case "月":
  509. startTimeRealTemp = startDateParse.AddDate(0, -v.LeadValue, 0)
  510. case "季":
  511. startTimeRealTemp = startDateParse.AddDate(0, -3*v.LeadValue, 0)
  512. case "周":
  513. startTimeRealTemp = startDateParse.AddDate(0, 0, -7*v.LeadValue)
  514. case "年":
  515. startTimeRealTemp = startDateParse.AddDate(-v.LeadValue, 0, 0)
  516. }
  517. if startTimeRealTemp.Before(startDateParse) {
  518. startDateReal = startTimeRealTemp.Format(utils.FormatDate)
  519. diffSeconds = (int64(startTimeRealTemp.UnixNano()) - int64(startDateParse.UnixNano())) / 1e6
  520. } else {
  521. startDateReal = startDate
  522. diffSeconds = 0
  523. }
  524. // 预测指标的开始日期也要偏移
  525. {
  526. day, tmpErr := utils.GetDaysBetween2Date(utils.FormatDate, startDate, startDateReal)
  527. if tmpErr != nil {
  528. err = tmpErr
  529. return
  530. }
  531. moveLatestDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, item.MoveLatestDate, time.Local)
  532. if tmpErr != nil {
  533. err = tmpErr
  534. return
  535. }
  536. item.MoveLatestDate = moveLatestDateTime.AddDate(0, 0, day).Format(utils.FormatDate)
  537. }
  538. } else {
  539. startDateReal = startDate
  540. }
  541. }
  542. //fmt.Println("line 1011 chart:", v.Source, v.EdbInfoId, startDateReal, endDate)
  543. calendarPreYear := 0
  544. if calendar == "农历" {
  545. newStartDateReal, err := time.Parse(utils.FormatDate, startDateReal)
  546. if err != nil {
  547. fmt.Println("time.Parse:" + err.Error())
  548. }
  549. calendarPreYear = newStartDateReal.Year() - 1
  550. newStartDateReal = newStartDateReal.AddDate(-1, 0, 0)
  551. startDateReal = newStartDateReal.Format(utils.FormatDate)
  552. }
  553. dataList := make([]*data_manage.EdbDataList, 0)
  554. dataListTmp, ok := dataListMap[v.EdbInfoId]
  555. if ok {
  556. dataList = dataListTmp
  557. } else {
  558. err = errors.New(fmt.Sprint("获取失败,指标类型异常", v.EdbInfoId))
  559. return
  560. }
  561. if v.IsConvert == 1 {
  562. switch v.ConvertType {
  563. case 1:
  564. for i, data := range dataList {
  565. dataList[i].Value = data.Value * v.ConvertValue
  566. }
  567. //item.MaxData = item.MaxData * v.ConvertValue
  568. //item.MinData = item.MinData * v.ConvertValue
  569. case 2:
  570. for i, data := range dataList {
  571. dataList[i].Value = data.Value / v.ConvertValue
  572. }
  573. //item.MaxData = item.MaxData / v.ConvertValue
  574. //item.MinData = item.MinData / v.ConvertValue
  575. case 3:
  576. for i, data := range dataList {
  577. if data.Value <= 0 {
  578. err = errors.New("数据中含有负数或0,无法对数运算")
  579. return
  580. }
  581. dataList[i].Value = math.Log(data.Value) / math.Log(v.ConvertValue)
  582. }
  583. //item.MaxData = math.Log(item.MaxData) / math.Log(v.ConvertValue)
  584. //item.MinData = math.Log(item.MinData) / math.Log(v.ConvertValue)
  585. }
  586. }
  587. edbDataListMap[v.EdbInfoId] = dataList
  588. if diffSeconds != 0 && v.EdbInfoType == 0 {
  589. dataListLen := len(dataList)
  590. for i := 0; i < dataListLen; i++ {
  591. dataList[i].DataTimestamp = dataList[i].DataTimestamp - diffSeconds
  592. }
  593. }
  594. if chartType == 2 {
  595. latestDate, tmpErr := time.Parse(utils.FormatDate, v.LatestDate)
  596. if tmpErr != nil {
  597. //item.DataList = dataList
  598. item.IsNullData = true
  599. edbList = append(edbList, item)
  600. continue
  601. }
  602. if calendar == "农历" {
  603. if len(dataList) <= 0 {
  604. result := new(data_manage.EdbDataResult)
  605. item.DataList = result
  606. } else {
  607. result, tmpErr := data_manage.AddCalculateQuarterV6(dataList)
  608. if tmpErr != nil {
  609. err = errors.New("获取农历数据失败,Err:" + tmpErr.Error())
  610. return
  611. }
  612. quarterDataList, tErr := GetSeasonEdbInfoDataListByXDateNong(result, latestDate, seasonExtraConfig, calendarPreYear)
  613. if tErr != nil {
  614. err = errors.New("获取季节性图表数据失败,Err:" + tErr.Error())
  615. return
  616. }
  617. item.DataList = quarterDataList
  618. }
  619. } else {
  620. quarterDataList, tErr := GetSeasonEdbInfoDataListByXDate(dataList, latestDate, seasonExtraConfig)
  621. if tErr != nil {
  622. err = errors.New("获取季节性图表数据失败,Err:" + tErr.Error())
  623. return
  624. }
  625. item.DataList = quarterDataList
  626. }
  627. } else if chartType == 7 || chartType == utils.CHART_TYPE_RADAR { //柱方图
  628. //item.DataList = dataList
  629. } else {
  630. item.DataList = dataList
  631. }
  632. edbList = append(edbList, item)
  633. }
  634. return
  635. }