chart_info_excel_balance.go 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941
  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, []int{})
  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. chartInfo = new(data_manage.ChartInfo)
  157. chartInfo.ChartName = req.ChartName
  158. //chartInfo.EdbInfoIds = edbInfoIdStr
  159. //chartInfo.ChartClassifyId = req.ChartClassifyId
  160. chartInfo.SysUserId = sysUserId
  161. chartInfo.SysUserRealName = sysUserRealName
  162. chartInfo.CreateTime = time.Now()
  163. chartInfo.ModifyTime = time.Now()
  164. chartInfo.IsSetName = 0
  165. timestamp := strconv.FormatInt(time.Now().UnixNano(), 10)
  166. chartInfo.UniqueCode = utils.MD5(utils.CHART_PREFIX + "_" + timestamp)
  167. // todo 判断是否需要重新计算用户的start_date
  168. chartInfo.DateType = 3
  169. if chartType == 0 {
  170. chartType = 1
  171. }
  172. chartInfo.ChartType = chartType
  173. calendar := req.Calendar
  174. if calendar == "" {
  175. calendar = "公历"
  176. }
  177. chartInfo.Calendar = calendar
  178. /* chartInfo.StartDate = req.StartDate
  179. chartInfo.EndDate = req.EndDate
  180. chartInfo.SeasonStartDate = req.StartDate
  181. chartInfo.SeasonEndDate = req.EndDate*/
  182. chartInfo.LeftMin = req.LeftMin
  183. chartInfo.LeftMax = req.LeftMax
  184. chartInfo.RightMin = req.RightMin
  185. chartInfo.RightMax = req.RightMax
  186. chartInfo.Right2Min = req.Right2Min
  187. chartInfo.Right2Max = req.Right2Max
  188. chartInfo.MinMaxSave = req.MinMaxSave
  189. //chartInfo.Disabled = disableVal
  190. //chartInfo.BarConfig = barChartConf
  191. chartInfo.ExtraConfig = extraConfig
  192. chartInfo.SeasonExtraConfig = seasonExtraConfig
  193. //chartInfo.StartYear = req.StartYear
  194. chartInfo.Source = utils.CHART_SOURCE_BALANCE_EXCEL
  195. // chartInfo.ChartThemeId = req.ChartThemeId
  196. chartInfo.SourcesFrom = req.SourcesFrom
  197. /* chartInfo.Instructions = req.Instructions
  198. chartInfo.MarkersLines = req.MarkersLines
  199. chartInfo.MarkersAreas = req.MarkersAreas
  200. chartInfo.Unit = req.Unit
  201. chartInfo.UnitEn = req.UnitEn*/
  202. /*newId, err := data_manage.AddChartInfo(chartInfo)
  203. if err != nil {
  204. errMsg = `保存失败`
  205. err = fmt.Errorf("保存失败,Err:" + err.Error())
  206. return
  207. }
  208. chartInfo.ChartInfoId = int(newId)*/
  209. //添加es数据
  210. //go EsAddOrEditChartInfo(chartInfo.ChartInfoId)
  211. return
  212. }
  213. // EditBalanceExcelChart 添加平衡表图表
  214. func EditBalanceExcelChart(req request.AddBalanceTableChartReq, sysUser *system.Admin) (chartInfo *data_manage.ChartInfo, err error, errMsg string, isSendEmail bool) {
  215. // 获取表格信息
  216. excelInfo, err := excelModel.GetExcelInfoById(req.ExcelInfoId)
  217. if err != nil {
  218. errMsg = "找不到该EXCEL"
  219. err = fmt.Errorf("找不到该EXCEL!%s", err.Error())
  220. return
  221. }
  222. if excelInfo.Source != utils.BALANCE_TABLE {
  223. errMsg = "EXCEL类型错误!"
  224. err = fmt.Errorf("EXCEL类型错误!")
  225. return
  226. }
  227. if len(req.ChartEdbInfoList) == 0 {
  228. errMsg = "图表数据不能为空!"
  229. err = fmt.Errorf("图表数据不能为空!%s", err.Error())
  230. return
  231. }
  232. //查询已有的mapping
  233. mapping, err := excelModel.GetExcelChartEdbMappingByChartInfoId(req.ChartInfoId)
  234. if err != nil {
  235. errMsg = "查询图表mapping失败!"
  236. err = fmt.Errorf("查询图表mapping失败!%s", err.Error())
  237. return
  238. }
  239. deleteMap := make(map[int]int)
  240. for _, v := range mapping {
  241. deleteMap[v.ExcelChartEdbId] = v.ExcelChartEdbId
  242. }
  243. // 查询edbIds
  244. chartEdbList := make([]*excelModel.AddChartEdbAndDataItem, 0)
  245. for _, chartEdb := range req.ChartEdbInfoList {
  246. if _, ok := deleteMap[chartEdb.ExcelChartEdbId]; ok {
  247. delete(deleteMap, chartEdb.ExcelChartEdbId)
  248. }
  249. excelChartEdbId := chartEdb.ExcelChartEdbId
  250. excelEdb, tmpErr := excelModel.GetExcelChartEdbById(excelChartEdbId)
  251. if tmpErr != nil {
  252. if tmpErr.Error() == utils.ErrNoRow() {
  253. errMsg = "指标不存在!"
  254. err = errors.New("指标不存在,edbInfoId:" + strconv.Itoa(excelChartEdbId))
  255. return
  256. } else {
  257. errMsg = "获取指标信息失败!"
  258. err = errors.New("获取图表的指标信息失败,Err:" + tmpErr.Error())
  259. return
  260. }
  261. }
  262. if excelEdb == nil {
  263. errMsg = "指标已被删除,请重新选择!"
  264. err = errors.New("指标不存在,ChartInfoId:" + strconv.Itoa(req.ChartInfoId))
  265. return
  266. } else {
  267. if excelEdb.ExcelChartEdbId <= 0 {
  268. errMsg = "指标已被删除,请重新选择!"
  269. err = errors.New("指标不存在,ChartInfoId:" + strconv.Itoa(req.ChartInfoId))
  270. return
  271. }
  272. }
  273. excelEdb.EdbName = chartEdb.EdbName
  274. excelEdb.DateSequence = chartEdb.DateSequenceStr
  275. excelEdb.DataSequence = chartEdb.DataSequenceStr
  276. excelEdb.MaxData = chartEdb.MaxData
  277. excelEdb.MinData = chartEdb.MinData
  278. excelEdb.IsOrder = chartEdb.IsOrder
  279. excelEdb.IsAxis = chartEdb.IsAxis
  280. excelEdb.FromTag = chartEdb.FromTag
  281. excelEdb.EdbInfoType = chartEdb.EdbInfoType
  282. excelEdb.LeadValue = chartEdb.LeadValue
  283. excelEdb.LeadUnit = chartEdb.LeadUnit
  284. excelEdb.ModifyTime = time.Now()
  285. var dateList []string
  286. var dataList []float64
  287. if excelInfo.BalanceType == 1 {
  288. // 如果是静态表,则直接使用前端传输的数据落到数据库里
  289. /*dateList, dataList, err, errMsg = utils.HandleEdbSequenceVal(chartEdb.DateSequenceVal, chartEdb.DataSequenceVal)
  290. if err != nil {
  291. errMsg = "时间序列或数据序列异常!"
  292. err = fmt.Errorf("时间序列或数据序列异常!%s", err.Error())
  293. return
  294. }*/
  295. }
  296. // 处理日期列表和值列表
  297. addItem := &excelModel.AddChartEdbAndDataItem{
  298. ChartEdb: excelEdb,
  299. DateList: dateList,
  300. ValList: dataList,
  301. }
  302. chartEdbList = append(chartEdbList, addItem)
  303. }
  304. chartInfo, err, errMsg, isSendEmail = editBalanceExcelChart(req)
  305. if err != nil {
  306. errMsg = "新增图表失败!"
  307. err = fmt.Errorf("新增图表失败!%s, %s", errMsg, err.Error())
  308. return
  309. }
  310. obj := new(excelModel.ExcelChartEdb)
  311. //删除原先多余的指标
  312. deleteEdbIds := make([]int, 0)
  313. for k, _ := range deleteMap {
  314. deleteEdbIds = append(deleteEdbIds, k)
  315. }
  316. err = obj.AddChartEdbAndData(chartEdbList, chartInfo, deleteEdbIds)
  317. if err != nil {
  318. errMsg = "新增图表失败!"
  319. err = fmt.Errorf("新增图表数据失败!%s", err.Error())
  320. return
  321. }
  322. return
  323. }
  324. func editBalanceExcelChart(req request.AddBalanceTableChartReq) (chartInfo *data_manage.ChartInfo, err error, errMsg string, isSendEmail bool) {
  325. isSendEmail = true // 默认错误的时候要发送邮件
  326. chartType := req.ChartType
  327. extraConfig := req.ExtraConfig
  328. chartInfo, err = data_manage.GetChartInfoById(req.ChartInfoId)
  329. if err != nil {
  330. if err.Error() == utils.ErrNoRow() {
  331. errMsg = "图表已被删除,请刷新页面"
  332. err = errors.New(errMsg)
  333. isSendEmail = false
  334. return
  335. }
  336. errMsg = "获取图表信息失败"
  337. err = errors.New("获取图表信息失败,Err:" + err.Error())
  338. return
  339. }
  340. // todo 查找默认主题设置
  341. // 季节性图表额外配置信息
  342. var seasonExtraConfig string
  343. if chartType == 2 {
  344. // 处理季节性图表横轴配置
  345. {
  346. if req.SeasonExtraConfig.XEndDate != "" {
  347. if req.SeasonExtraConfig.XStartDate > req.SeasonExtraConfig.XEndDate && req.SeasonExtraConfig.JumpYear != 1 {
  348. errMsg = "季节性图表配置信息异常:横坐标日期配置错误"
  349. err = fmt.Errorf("季节性图表配置信息异常: 横坐标日期配置错误")
  350. return
  351. }
  352. seasonExtra, tErr := json.Marshal(req.SeasonExtraConfig)
  353. if tErr != nil {
  354. errMsg = "季节性图表配置信息异常"
  355. err = fmt.Errorf("季节性图表配置信息异常,Err:" + tErr.Error())
  356. return
  357. }
  358. seasonExtraConfig = string(seasonExtra)
  359. }
  360. }
  361. }
  362. /*var extraConfigEdbInfoIdArr []int
  363. extraConfigEdbInfoIdArr, err, errMsg = CheckChartExtraConfig(req.ChartType, req.ExtraConfig)
  364. if err != nil {
  365. err = errors.New("添加失败:" + err.Error())
  366. return
  367. }*/
  368. // 图表额外配置
  369. extraConfig, err, errMsg = HandleExtraConfig(chartType, extraConfig)
  370. if err != nil {
  371. if errMsg == `` {
  372. errMsg = "指标异常!"
  373. }
  374. err = fmt.Errorf("指标异常!Err:" + err.Error())
  375. return
  376. }
  377. //判断图表是否存在
  378. var condition string
  379. var pars []interface{}
  380. condition += " AND chart_info_id<>? "
  381. pars = append(pars, req.ChartInfoId)
  382. // 图表名称在不同图分类下不允许重复 需求调整时间:2022年11月07日09:47:07
  383. condition += " AND chart_classify_id=0 "
  384. condition += " AND chart_name=? AND source = ? "
  385. pars = append(pars, req.ChartName, utils.CHART_SOURCE_BALANCE_EXCEL)
  386. count, err := data_manage.GetChartInfoCountByCondition(condition, pars)
  387. if err != nil {
  388. errMsg = "判断图表名称是否存在失败"
  389. err = fmt.Errorf("判断图表名称是否存在失败,Err:" + err.Error())
  390. return
  391. }
  392. if count > 0 {
  393. errMsg = "图表已存在,请重新填写"
  394. err = fmt.Errorf("判断图表名称是否存在失败")
  395. isSendEmail = false
  396. return
  397. }
  398. // todo 判断是否是禁用的图表
  399. // disableVal := data.CheckIsDisableChart(edbInfoIdArr)
  400. chartInfo.ChartName = req.ChartName
  401. //chartInfo.EdbInfoIds = edbInfoIdStr
  402. //chartInfo.ChartClassifyId = req.ChartClassifyId
  403. chartInfo.ModifyTime = time.Now()
  404. chartInfo.IsSetName = 0
  405. // todo 判断是否需要重新计算用户的start_date
  406. chartInfo.DateType = 3
  407. if chartType == 0 {
  408. chartType = 1
  409. }
  410. chartInfo.ChartType = chartType
  411. calendar := req.Calendar
  412. if calendar == "" {
  413. calendar = "公历"
  414. }
  415. chartInfo.Calendar = calendar
  416. /* chartInfo.StartDate = req.StartDate
  417. chartInfo.EndDate = req.EndDate
  418. chartInfo.SeasonStartDate = req.StartDate
  419. chartInfo.SeasonEndDate = req.EndDate*/
  420. chartInfo.LeftMin = req.LeftMin
  421. chartInfo.LeftMax = req.LeftMax
  422. chartInfo.RightMin = req.RightMin
  423. chartInfo.RightMax = req.RightMax
  424. chartInfo.Right2Min = req.Right2Min
  425. chartInfo.Right2Max = req.Right2Max
  426. chartInfo.MinMaxSave = req.MinMaxSave
  427. //chartInfo.Disabled = disableVal
  428. //chartInfo.BarConfig = barChartConf
  429. chartInfo.ExtraConfig = extraConfig
  430. chartInfo.SeasonExtraConfig = seasonExtraConfig
  431. //chartInfo.StartYear = req.StartYear
  432. chartInfo.Source = utils.CHART_SOURCE_BALANCE_EXCEL
  433. // chartInfo.ChartThemeId = req.ChartThemeId
  434. chartInfo.SourcesFrom = req.SourcesFrom
  435. /* chartInfo.Instructions = req.Instructions
  436. chartInfo.MarkersLines = req.MarkersLines
  437. chartInfo.MarkersAreas = req.MarkersAreas
  438. chartInfo.Unit = req.Unit
  439. chartInfo.UnitEn = req.UnitEn*/
  440. /*newId, err := data_manage.AddChartInfo(chartInfo)
  441. if err != nil {
  442. errMsg = `保存失败`
  443. err = fmt.Errorf("保存失败,Err:" + err.Error())
  444. return
  445. }
  446. chartInfo.ChartInfoId = int(newId)*/
  447. //添加es数据
  448. //go EsAddOrEditChartInfo(chartInfo.ChartInfoId)
  449. return
  450. }
  451. 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) {
  452. // todo 图表权限处理
  453. chartInfoId := chartInfo.ChartInfoId
  454. resp = new(data_manage.ChartInfoDetailResp)
  455. // 获取主题样式
  456. chartTheme, err := GetChartThemeConfig(chartInfo.ChartThemeId, chartInfo.Source, chartInfo.ChartType)
  457. if err != nil {
  458. errMsg = "获取失败"
  459. err = fmt.Errorf(" 获取主题信息失败 Err:%s", err.Error())
  460. return
  461. }
  462. chartInfo.ChartThemeStyle = chartTheme.Config
  463. chartInfo.ChartThemeId = chartTheme.ChartThemeId
  464. dateType := chartInfo.DateType
  465. fmt.Println("dateType:", dateType)
  466. chartType := chartInfo.ChartType
  467. startDate := chartInfo.StartDate
  468. endDate := chartInfo.EndDate
  469. seasonStartDate := chartInfo.SeasonStartDate
  470. seasonEndDate := chartInfo.SeasonEndDate
  471. //startYear := chartInfo.StartYear
  472. calendar := chartInfo.Calendar
  473. if calendar == "" {
  474. calendar = "公历"
  475. }
  476. mappingList := make([]*data_manage.ChartEdbInfoMapping, 0)
  477. //循环组装映射关系
  478. for _, v := range mappingListTmp {
  479. mapping := &data_manage.ChartEdbInfoMapping{
  480. EdbInfoId: v.ExcelChartEdbId,
  481. SourceName: "",
  482. Source: 0,
  483. SubSource: 0,
  484. EdbCode: v.EdbCode,
  485. EdbName: v.EdbName,
  486. EdbAliasName: v.EdbName,
  487. EdbNameEn: "",
  488. EdbAliasNameEn: "",
  489. EdbType: 0,
  490. Frequency: "",
  491. FrequencyEn: "",
  492. Unit: "",
  493. UnitEn: "",
  494. StartDate: "",
  495. EndDate: "",
  496. ModifyTime: v.ModifyTime.Format(utils.FormatDateTime),
  497. ChartEdbMappingId: v.ExcelChartEdbId,
  498. ChartInfoId: chartInfoId,
  499. MaxData: v.MaxData,
  500. MinData: v.MinData,
  501. IsOrder: v.IsOrder,
  502. IsAxis: v.IsAxis,
  503. //EdbInfoType: 0,
  504. //EdbInfoCategoryType: 0,
  505. LeadValue: v.LeadValue,
  506. LeadUnit: v.LeadUnit,
  507. LeadUnitEn: "",
  508. ChartStyle: "",
  509. ChartColor: "",
  510. PredictChartColor: "",
  511. ChartWidth: 0,
  512. ChartType: 0,
  513. LatestDate: "",
  514. LatestValue: 0,
  515. MoveLatestDate: "",
  516. UniqueCode: "",
  517. MinValue: 0,
  518. MaxValue: 0,
  519. DataList: nil,
  520. IsNullData: false,
  521. MappingSource: 0,
  522. RegionType: "",
  523. ClassifyId: 0,
  524. IsConvert: 0,
  525. ConvertType: 0,
  526. ConvertValue: 0,
  527. ConvertUnit: "",
  528. ConvertEnUnit: "",
  529. IsJoinPermission: 0,
  530. HaveOperaAuth: true,
  531. }
  532. mappingList = append(mappingList, mapping)
  533. }
  534. if chartType == 2 {
  535. startDate = seasonStartDate
  536. endDate = seasonEndDate
  537. if dateType <= 0 {
  538. if startDate != "" {
  539. dateType = 5
  540. } else {
  541. dateType = utils.DateTypeNYears
  542. }
  543. }
  544. } else {
  545. if dateType <= 0 {
  546. dateType = 3
  547. }
  548. }
  549. /*yearMax := 0
  550. if dateType == utils.DateTypeNYears {
  551. for _, v := range mappingList {
  552. if v.LatestDate != "" {
  553. lastDateT, tErr := time.Parse(utils.FormatDate, v.LatestDate)
  554. if tErr != nil {
  555. br.Msg = "获取失败"
  556. br.ErrMsg = "获取图表日期信息失败,Err:" + tErr.Error()
  557. return
  558. }
  559. if lastDateT.Year() > yearMax {
  560. yearMax = lastDateT.Year()
  561. }
  562. }
  563. }
  564. }
  565. startDate, endDate = utils.GetDateByDateTypeV2(dateType, startDate, endDate, startYear, yearMax)*/
  566. if chartInfo.ChartType == 2 {
  567. chartInfo.StartDate = startDate
  568. chartInfo.EndDate = endDate
  569. }
  570. // 图表额外数据参数
  571. extraConfigStr := chartInfo.ExtraConfig
  572. // 柱方图的一些配置
  573. var barConfig data_manage.BarChartInfoReq
  574. if chartInfo != nil && chartInfo.ChartType == 7 {
  575. if chartInfo.BarConfig == `` {
  576. err = fmt.Errorf("柱方图未配置")
  577. errMsg = "柱方图未配置"
  578. return
  579. }
  580. err = json.Unmarshal([]byte(chartInfo.BarConfig), &barConfig)
  581. if err != nil {
  582. err = fmt.Errorf("柱方图配置异常 json.Unmarshal Err:%s", err.Error())
  583. errMsg = "柱方图配置异常"
  584. return
  585. }
  586. extraConfigStr = chartInfo.BarConfig
  587. }
  588. // 获取表格数据
  589. excelChartInfoDataShow := new(ExcelChartInfoDataShow)
  590. excelChartInfoDataShow.DataListMap = dataListMap
  591. if chartInfo.HaveOperaAuth || true {
  592. // 获取图表中的指标数据
  593. edbList, xEdbIdValue, yDataList, dataResp, e, msg := GetChartEdbDataV2(chartInfoId, chartType, calendar, startDate, endDate, mappingList, extraConfigStr, chartInfo.SeasonExtraConfig, excelChartInfoDataShow)
  594. if e != nil {
  595. err = fmt.Errorf("获取图表,指标数据失败,Err:%s", e.Error())
  596. errMsg = msg
  597. return
  598. }
  599. // 单位
  600. if chartType == utils.CHART_TYPE_BAR && len(yDataList) > 0 {
  601. chartInfo.Unit = yDataList[0].Unit
  602. chartInfo.UnitEn = yDataList[0].UnitEn
  603. }
  604. warnEdbList := make([]string, 0)
  605. for _, v := range edbList {
  606. if v.IsNullData {
  607. warnEdbList = append(warnEdbList, v.EdbName+"("+v.EdbCode+")")
  608. }
  609. }
  610. if len(warnEdbList) > 0 {
  611. chartInfo.WarnMsg = `图表引用指标异常,异常指标:` + strings.Join(warnEdbList, ",")
  612. }
  613. if chartInfoId > 0 && chartInfo != nil {
  614. //判断是否加入我的图库
  615. {
  616. var myChartCondition string
  617. var myChartPars []interface{}
  618. myChartCondition += ` AND a.admin_id=? `
  619. myChartPars = append(myChartPars, sysUser.AdminId)
  620. myChartCondition += ` AND a.chart_info_id=? `
  621. myChartPars = append(myChartPars, chartInfo.ChartInfoId)
  622. myChartList, e := data_manage.GetMyChartByCondition(myChartCondition, myChartPars)
  623. if e != nil && e.Error() != utils.ErrNoRow() {
  624. errMsg = "获取失败"
  625. err = fmt.Errorf("获取我的图表信息失败,GetMyChartByCondition,Err:" + e.Error())
  626. return
  627. }
  628. if myChartList != nil && len(myChartList) > 0 {
  629. chartInfo.IsAdd = true
  630. chartInfo.MyChartId = myChartList[0].MyChartId
  631. chartInfo.MyChartClassifyId = myChartList[0].MyChartClassifyId
  632. }
  633. }
  634. }
  635. //判断是否需要展示英文标识
  636. chartInfo.IsEnChart = CheckIsEnChart(chartInfo.ChartNameEn, edbList, chartInfo.Source, chartInfo.ChartType)
  637. // 图表的指标来源
  638. sourceNameList, sourceNameEnList := GetEdbSourceByEdbInfoIdList(edbList)
  639. chartInfo.ChartSource = strings.Join(sourceNameList, ",")
  640. chartInfo.ChartSourceEn = strings.Join(sourceNameEnList, ",")
  641. // todo 指标权限
  642. {
  643. for _, item := range edbList {
  644. // 数据权限
  645. item.HaveOperaAuth = true
  646. }
  647. }
  648. resp.EdbInfoList = edbList
  649. resp.XEdbIdValue = xEdbIdValue
  650. resp.YDataList = yDataList
  651. resp.DataResp = dataResp
  652. } else {
  653. resp.EdbInfoList = mappingList
  654. }
  655. //图表操作权限
  656. chartInfo.IsEdit = CheckOpChartPermission(sysUser, chartInfo.SysUserId, chartInfo.HaveOperaAuth)
  657. chartInfo.Button = data_manage.ChartViewButton{
  658. IsEdit: chartInfo.IsEdit,
  659. IsEnChart: chartInfo.IsEnChart,
  660. IsAdd: chartInfo.IsAdd,
  661. IsCopy: true,
  662. IsSetName: chartInfo.IsSetName,
  663. }
  664. resp.ChartInfo = chartInfo
  665. resp.BarChartInfo = barConfig
  666. return
  667. }
  668. // GetBalanceExcelEdbDataMapList 获取指标最后的基础数据
  669. 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) {
  670. // 指标对应的所有数据
  671. edbDataListMap = make(map[int][]*data_manage.EdbDataList)
  672. for _, v := range mappingList {
  673. //fmt.Println("v:", v.EdbInfoId)
  674. item := new(data_manage.ChartEdbInfoMapping)
  675. item.EdbInfoId = v.EdbInfoId
  676. item.SourceName = v.SourceName
  677. item.Source = v.Source
  678. item.EdbCode = v.EdbCode
  679. item.EdbName = v.EdbName
  680. item.EdbNameEn = v.EdbNameEn
  681. item.Frequency = v.Frequency
  682. item.EdbType = v.EdbType
  683. item.FrequencyEn = GetFrequencyEn(v.Frequency)
  684. if v.Unit != `无` {
  685. item.Unit = v.Unit
  686. }
  687. item.UnitEn = v.UnitEn
  688. item.StartDate = v.StartDate
  689. item.EndDate = v.EndDate
  690. item.ModifyTime = v.ModifyTime
  691. item.EdbInfoCategoryType = v.EdbInfoCategoryType
  692. item.PredictChartColor = v.PredictChartColor
  693. item.ClassifyId = v.ClassifyId
  694. if chartInfoId <= 0 {
  695. item.IsAxis = 1
  696. item.LeadValue = 0
  697. item.LeadUnit = ""
  698. item.ChartEdbMappingId = 0
  699. item.ChartInfoId = 0
  700. item.IsOrder = false
  701. item.EdbInfoType = 1
  702. item.ChartStyle = ""
  703. item.ChartColor = ""
  704. item.ChartWidth = 0
  705. item.MaxData = v.MaxValue
  706. item.MinData = v.MinValue
  707. } else {
  708. item.IsAxis = v.IsAxis
  709. item.EdbInfoType = v.EdbInfoType
  710. item.LeadValue = v.LeadValue
  711. item.LeadUnit = v.LeadUnit
  712. item.LeadUnitEn = GetLeadUnitEn(v.LeadUnit)
  713. item.ChartEdbMappingId = v.ChartEdbMappingId
  714. item.ChartInfoId = v.ChartInfoId
  715. item.ChartStyle = v.ChartStyle
  716. item.ChartColor = v.ChartColor
  717. item.ChartWidth = v.ChartWidth
  718. item.IsOrder = v.IsOrder
  719. item.MaxData = v.MaxData
  720. item.MinData = v.MinData
  721. }
  722. item.LatestValue = v.LatestValue
  723. item.LatestDate = v.LatestDate
  724. item.UniqueCode = v.UniqueCode
  725. item.MoveLatestDate = v.LatestDate
  726. item.EdbAliasName = v.EdbAliasName
  727. item.IsConvert = v.IsConvert
  728. item.ConvertType = v.ConvertType
  729. item.ConvertValue = v.ConvertValue
  730. item.ConvertUnit = v.ConvertUnit
  731. item.ConvertEnUnit = v.ConvertEnUnit
  732. item.IsJoinPermission = v.IsJoinPermission
  733. var startDateReal string
  734. var diffSeconds int64
  735. if chartType == 2 { //季节性图
  736. startDateReal = startDate
  737. } else {
  738. if v.EdbInfoType == 0 && v.LeadUnit != "" && v.LeadValue > 0 { //领先指标
  739. var startTimeRealTemp time.Time
  740. startDateParse, _ := time.Parse(utils.FormatDate, startDate)
  741. switch v.LeadUnit {
  742. case "天":
  743. startTimeRealTemp = startDateParse.AddDate(0, 0, -v.LeadValue)
  744. case "月":
  745. startTimeRealTemp = startDateParse.AddDate(0, -v.LeadValue, 0)
  746. case "季":
  747. startTimeRealTemp = startDateParse.AddDate(0, -3*v.LeadValue, 0)
  748. case "周":
  749. startTimeRealTemp = startDateParse.AddDate(0, 0, -7*v.LeadValue)
  750. case "年":
  751. startTimeRealTemp = startDateParse.AddDate(-v.LeadValue, 0, 0)
  752. }
  753. if startTimeRealTemp.Before(startDateParse) {
  754. startDateReal = startTimeRealTemp.Format(utils.FormatDate)
  755. diffSeconds = (int64(startTimeRealTemp.UnixNano()) - int64(startDateParse.UnixNano())) / 1e6
  756. } else {
  757. startDateReal = startDate
  758. diffSeconds = 0
  759. }
  760. // 预测指标的开始日期也要偏移
  761. {
  762. day, tmpErr := utils.GetDaysBetween2Date(utils.FormatDate, startDate, startDateReal)
  763. if tmpErr != nil {
  764. err = tmpErr
  765. return
  766. }
  767. moveLatestDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, item.MoveLatestDate, time.Local)
  768. if tmpErr != nil {
  769. err = tmpErr
  770. return
  771. }
  772. item.MoveLatestDate = moveLatestDateTime.AddDate(0, 0, day).Format(utils.FormatDate)
  773. }
  774. } else {
  775. startDateReal = startDate
  776. }
  777. }
  778. //fmt.Println("line 1011 chart:", v.Source, v.EdbInfoId, startDateReal, endDate)
  779. calendarPreYear := 0
  780. if calendar == "农历" {
  781. newStartDateReal, err := time.Parse(utils.FormatDate, startDateReal)
  782. if err != nil {
  783. fmt.Println("time.Parse:" + err.Error())
  784. }
  785. calendarPreYear = newStartDateReal.Year() - 1
  786. newStartDateReal = newStartDateReal.AddDate(-1, 0, 0)
  787. startDateReal = newStartDateReal.Format(utils.FormatDate)
  788. }
  789. dataList := make([]*data_manage.EdbDataList, 0)
  790. dataListTmp, ok := dataListMap[v.EdbInfoId]
  791. if ok {
  792. dataList = dataListTmp
  793. } else {
  794. err = errors.New(fmt.Sprint("获取失败,指标类型异常", v.EdbInfoId))
  795. return
  796. }
  797. if v.IsConvert == 1 {
  798. switch v.ConvertType {
  799. case 1:
  800. for i, data := range dataList {
  801. dataList[i].Value = data.Value * v.ConvertValue
  802. }
  803. //item.MaxData = item.MaxData * v.ConvertValue
  804. //item.MinData = item.MinData * v.ConvertValue
  805. case 2:
  806. for i, data := range dataList {
  807. dataList[i].Value = data.Value / v.ConvertValue
  808. }
  809. //item.MaxData = item.MaxData / v.ConvertValue
  810. //item.MinData = item.MinData / v.ConvertValue
  811. case 3:
  812. for i, data := range dataList {
  813. if data.Value <= 0 {
  814. err = errors.New("数据中含有负数或0,无法对数运算")
  815. return
  816. }
  817. dataList[i].Value = math.Log(data.Value) / math.Log(v.ConvertValue)
  818. }
  819. //item.MaxData = math.Log(item.MaxData) / math.Log(v.ConvertValue)
  820. //item.MinData = math.Log(item.MinData) / math.Log(v.ConvertValue)
  821. }
  822. }
  823. edbDataListMap[v.EdbInfoId] = dataList
  824. if diffSeconds != 0 && v.EdbInfoType == 0 {
  825. dataListLen := len(dataList)
  826. for i := 0; i < dataListLen; i++ {
  827. dataList[i].DataTimestamp = dataList[i].DataTimestamp - diffSeconds
  828. }
  829. }
  830. if chartType == 2 {
  831. latestDate, tmpErr := time.Parse(utils.FormatDate, v.LatestDate)
  832. if tmpErr != nil {
  833. //item.DataList = dataList
  834. item.IsNullData = true
  835. edbList = append(edbList, item)
  836. continue
  837. }
  838. if calendar == "农历" {
  839. if len(dataList) <= 0 {
  840. result := new(data_manage.EdbDataResult)
  841. item.DataList = result
  842. } else {
  843. result, tmpErr := data_manage.AddCalculateQuarterV6(dataList)
  844. if tmpErr != nil {
  845. err = errors.New("获取农历数据失败,Err:" + tmpErr.Error())
  846. return
  847. }
  848. quarterDataList, tErr := GetSeasonEdbInfoDataListByXDateNong(result, latestDate, seasonExtraConfig, calendarPreYear)
  849. if tErr != nil {
  850. err = errors.New("获取季节性图表数据失败,Err:" + tErr.Error())
  851. return
  852. }
  853. item.DataList = quarterDataList
  854. }
  855. } else {
  856. quarterDataList, tErr := GetSeasonEdbInfoDataListByXDate(dataList, latestDate, seasonExtraConfig)
  857. if tErr != nil {
  858. err = errors.New("获取季节性图表数据失败,Err:" + tErr.Error())
  859. return
  860. }
  861. item.DataList = quarterDataList
  862. }
  863. } else if chartType == 7 || chartType == utils.CHART_TYPE_RADAR { //柱方图
  864. //item.DataList = dataList
  865. } else {
  866. item.DataList = dataList
  867. }
  868. edbList = append(edbList, item)
  869. }
  870. return
  871. }