chart_info.go 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550
  1. package chart
  2. import (
  3. "context"
  4. "fmt"
  5. "github.com/gin-gonic/gin"
  6. "hongze/hongze_yb/controller/response"
  7. "hongze/hongze_yb/global"
  8. "hongze/hongze_yb/models/response/chart_info"
  9. chartEdbMappingModel "hongze/hongze_yb/models/tables/chart_edb_mapping"
  10. chartInfoModel "hongze/hongze_yb/models/tables/chart_info"
  11. "hongze/hongze_yb/models/tables/chart_info_log"
  12. edbDataModel "hongze/hongze_yb/models/tables/edb_data"
  13. edbInfoModel "hongze/hongze_yb/models/tables/edb_info"
  14. "hongze/hongze_yb/services/alarm_msg"
  15. "hongze/hongze_yb/services/chart"
  16. edbDataService "hongze/hongze_yb/services/edb_data"
  17. "hongze/hongze_yb/services/user"
  18. "hongze/hongze_yb/utils"
  19. "io/ioutil"
  20. "sort"
  21. "strconv"
  22. "strings"
  23. "time"
  24. )
  25. // GetChartInfoDetail 获取图表详情
  26. // @Tags 图库模块
  27. // @Summary 获取图表详情
  28. // @Description 获取图表详情
  29. // @Security ApiKeyAuth
  30. // @Param Authorization header string true "Bearer 31a165baebe6dec616b1f8f3207b4273"
  31. // @Accept json
  32. // @Product json
  33. // @Param DateType query string false "时间段:1-00年至今; 2-10年至今; 3-15年至今; 4-21年至今; 5-指定区间; 6-指定年月至今; 7-18年至今; 8-19年至今; 9-20年至今"
  34. // @Param ClassifyId query string false "图表分类ID"
  35. // @Success 200 {object} chart_info.ChartInfoDetailResp
  36. // @failure 400 {string} string "图表详情获取失败"
  37. // @Router /my_chart/getChartInfoDetail [get]
  38. func GetChartInfoDetail(c *gin.Context) {
  39. // 图表ID
  40. reqChartInfoId := c.DefaultQuery("ChartInfoId", "")
  41. if reqChartInfoId == "" {
  42. response.Fail("参数有误:图表ID", c)
  43. return
  44. }
  45. chartInfoId, _ := strconv.Atoi(reqChartInfoId)
  46. startDate := c.DefaultQuery("StartDate", "")
  47. endDate := c.DefaultQuery("EndDate", "")
  48. // 图表样式类型
  49. reqChartType := c.DefaultQuery("ChartType", "")
  50. chartType, _ := strconv.Atoi(reqChartType)
  51. // 季节性图表时间
  52. reqSeasonStartDate := c.DefaultQuery("SeasonStartDate", "")
  53. reqSeasonEndDate := c.DefaultQuery("SeasonEndDate", "")
  54. // 指标ID
  55. edbInfoId := c.DefaultQuery("EdbInfoId", "")
  56. // 公历/农历
  57. reqCalendar := c.DefaultQuery("Calendar", "")
  58. // 获取图表信息
  59. var err error
  60. chartInfo := new(chartInfoModel.ChartInfoView)
  61. chartInfo, err = chartInfoModel.GetChartInfoViewById(chartInfoId)
  62. if err != nil {
  63. if err == utils.ErrNoRow {
  64. response.Fail("图表不存在,请刷新页面", c)
  65. return
  66. }
  67. response.FailMsg("获取失败", "获取图表信息失败, Err:"+err.Error(), c)
  68. return
  69. }
  70. chartType = chartInfo.ChartType
  71. calendar := chartInfo.Calendar
  72. if reqCalendar != "" {
  73. calendar = reqCalendar
  74. }
  75. // 时段筛选
  76. reqDateType := c.DefaultQuery("DateType", "")
  77. dateType := chartInfo.DateType
  78. if reqDateType != "" {
  79. dateType, _ = strconv.Atoi(reqDateType)
  80. }
  81. if dateType <= 0 {
  82. dateType = 3 // 默认同后台15年至今
  83. }
  84. switch dateType {
  85. case 1:
  86. startDate = "2000-01-01"
  87. case 2:
  88. startDate = "2010-01-01"
  89. case 3:
  90. startDate = "2015-01-01"
  91. case 4:
  92. startDate = "2021-01-01"
  93. case 5:
  94. if startDate == "" && chartInfo.StartDate != "" {
  95. startDate = chartInfo.StartDate
  96. endDate = chartInfo.EndDate
  97. } else {
  98. startDate = startDate + "-01"
  99. endDate = endDate + "-01"
  100. }
  101. case 6:
  102. if startDate == "" && chartInfo.StartDate != "" {
  103. startDate = chartInfo.StartDate
  104. } else {
  105. startDate = startDate + "-01"
  106. }
  107. case 7:
  108. startDate = "2018-01-01"
  109. case 8:
  110. startDate = "2019-01-01"
  111. case 9:
  112. startDate = "2020-01-01"
  113. case 11:
  114. startDate = "2022-01-01"
  115. }
  116. if chartType == 2 {
  117. // 季节性图表
  118. var seasonStartDate, seasonEndDate string
  119. if reqSeasonStartDate == "" {
  120. seasonStartDate = chartInfo.SeasonStartDate
  121. } else {
  122. seasonStartDate = reqSeasonStartDate
  123. }
  124. if reqSeasonEndDate == "" {
  125. seasonEndDate = chartInfo.SeasonEndDate
  126. } else {
  127. seasonEndDate = reqSeasonEndDate
  128. }
  129. if seasonStartDate != "" {
  130. startDate = seasonStartDate + "-01-01"
  131. } else {
  132. fivePre := time.Now().AddDate(-4, 0, 0).Year()
  133. startDate = strconv.Itoa(fivePre) + "-01-01"
  134. }
  135. if seasonEndDate != "" {
  136. endDate = seasonEndDate + "-12-31"
  137. } else {
  138. endDate = time.Now().Format(utils.FormatDate)
  139. }
  140. }
  141. // 获取图表指标映射
  142. mappingList := make([]*chartEdbMappingModel.ChartEdbInfoMapping, 0)
  143. if chartInfoId > 0 {
  144. mappingList, err = chartEdbMappingModel.GetMappingListByChartInfoId(chartInfoId)
  145. if err != nil {
  146. response.FailMsg("获取失败", "获取图表指标信息失败4001, Err:"+err.Error(), c)
  147. return
  148. }
  149. } else {
  150. if edbInfoId != "" {
  151. mappingList, err = chartEdbMappingModel.GetMappingListByEdbInfoId(edbInfoId)
  152. if err != nil {
  153. response.FailMsg("获取失败", "获取图表指标信息失败4002, Err:"+err.Error(), c)
  154. return
  155. }
  156. }
  157. }
  158. // 指标列表
  159. sourceArr := make([]string, 0)
  160. edbList := make([]*chartEdbMappingModel.ChartEdbInfoMappingList, 0)
  161. for _, v := range mappingList {
  162. item := new(chartEdbMappingModel.ChartEdbInfoMappingList)
  163. item.EdbInfoId = v.EdbInfoId
  164. item.SourceName = v.SourceName
  165. item.Source = v.Source
  166. item.EdbCode = v.EdbCode
  167. item.EdbName = v.EdbName
  168. item.Frequency = v.Frequency
  169. if v.Unit != "无" {
  170. item.Unit = v.Unit
  171. }
  172. item.StartDate = v.StartDate
  173. item.EndDate = v.EndDate
  174. item.ModifyTime = v.ModifyTime
  175. if !utils.InArray(v.SourceName, sourceArr) {
  176. sourceArr = append(sourceArr, v.SourceName)
  177. }
  178. if chartInfoId <= 0 {
  179. item.IsAxis = 1
  180. item.LeadValue = 0
  181. item.LeadUnit = ""
  182. item.ChartEdbMappingId = 0
  183. item.ChartInfoId = 0
  184. item.IsOrder = false
  185. item.EdbInfoType = 1
  186. item.ChartStyle = ""
  187. item.ChartColor = ""
  188. item.ChartWidth = 0
  189. item.MaxData = v.MaxValue
  190. item.MinData = v.MinValue
  191. } else {
  192. item.IsAxis = v.IsAxis
  193. item.EdbInfoType = v.EdbInfoType
  194. item.LeadValue = v.LeadValue
  195. item.LeadUnit = v.LeadUnit
  196. item.ChartEdbMappingId = v.ChartEdbMappingId
  197. item.ChartInfoId = v.ChartInfoId
  198. item.ChartStyle = v.ChartStyle
  199. item.ChartColor = v.ChartColor
  200. item.ChartWidth = v.ChartWidth
  201. item.IsOrder = v.IsOrder
  202. item.MaxData = v.MaxData
  203. item.MinData = v.MinData
  204. }
  205. item.LatestValue = v.LatestValue
  206. item.LatestDate = v.LatestDate
  207. item.UniqueCode = v.UniqueCode
  208. item.ChartStyle = v.ChartStyle
  209. var startDateReal string
  210. var diffSeconds int64
  211. if chartType == 2 { //季节性图表
  212. startDateReal = startDate
  213. } else {
  214. if v.EdbInfoType == 0 && v.LeadUnit != "" && v.LeadValue > 0 {
  215. // 领先指标
  216. var startTimeRealTemp time.Time
  217. startDateParse, _ := time.Parse(utils.FormatDate, startDate)
  218. switch v.LeadUnit {
  219. case "天":
  220. startTimeRealTemp = startDateParse.AddDate(0, 0, -v.LeadValue)
  221. case "月":
  222. startTimeRealTemp = startDateParse.AddDate(0, -v.LeadValue, 0)
  223. case "季":
  224. startTimeRealTemp = startDateParse.AddDate(0, -3*v.LeadValue, 0)
  225. case "周":
  226. startTimeRealTemp = startDateParse.AddDate(0, 0, -7*v.LeadValue)
  227. case "年":
  228. startTimeRealTemp = startDateParse.AddDate(-v.LeadValue, 0, 0)
  229. }
  230. if startTimeRealTemp.Before(startDateParse) {
  231. startDateReal = startTimeRealTemp.Format(utils.FormatDate)
  232. diffSeconds = (int64(startTimeRealTemp.UnixNano()) - int64(startDateParse.UnixNano())) / 1e6
  233. } else {
  234. startDateReal = startDate
  235. diffSeconds = 0
  236. }
  237. } else {
  238. startDateReal = startDate
  239. }
  240. }
  241. //fmt.Println("line 1011 chart:", v.Source, v.EdbInfoId, startDateReal, endDate)
  242. calendarPreYear := 0
  243. if calendar == "农历" {
  244. newStartDateReal, err := time.Parse(utils.FormatDate, startDateReal)
  245. if err != nil {
  246. response.FailMsg("获取失败", "农历时间转换有误4001, Err:"+err.Error(), c)
  247. //fmt.Println("time.Parse:" + err.Error())
  248. return
  249. }
  250. calendarPreYear = newStartDateReal.Year() - 1
  251. newStartDateReal = newStartDateReal.AddDate(-1, 0, 0)
  252. startDateReal = newStartDateReal.Format(utils.FormatDate)
  253. }
  254. dataList := make([]*edbDataModel.EdbDataList, 0)
  255. fmt.Println("chart:", v.Source, v.EdbInfoId, startDateReal, endDate)
  256. dataList, err = edbDataModel.GetEdbDataList(v.Source, v.EdbInfoId, startDateReal, endDate)
  257. if err != nil {
  258. response.FailMsg("获取失败", "获取图表指标信息失败4003, Err:"+err.Error(), c)
  259. return
  260. }
  261. if diffSeconds != 0 && v.EdbInfoType == 0 {
  262. dataListLen := len(dataList)
  263. for i := 0; i < dataListLen; i++ {
  264. dataList[i].DataTimestamp = dataList[i].DataTimestamp - diffSeconds
  265. }
  266. }
  267. if chartType == 2 {
  268. if calendar == "农历" {
  269. if len(dataList) <= 0 {
  270. result := new(edbDataModel.EdbDataResult)
  271. item.DataList = result
  272. } else {
  273. result, err := edbDataService.AddCalculateQuarter(dataList)
  274. if err != nil {
  275. response.FailMsg("获取失败", "获取农历数据失败4002, Err:"+err.Error(), c)
  276. return
  277. }
  278. if result.List[0].Year != calendarPreYear {
  279. itemList := make([]*edbDataModel.EdbDataList, 0)
  280. items := new(edbDataModel.EdbDataItems)
  281. //items.Year = calendarPreYear
  282. items.Items = itemList
  283. newResult := new(edbDataModel.EdbDataResult)
  284. newResult.List = append(newResult.List, items)
  285. newResult.List = append(newResult.List, result.List...)
  286. item.DataList = newResult
  287. } else {
  288. item.DataList = result
  289. }
  290. }
  291. } else {
  292. currentYear := time.Now().Year()
  293. quarterDataList := make([]*edbDataModel.QuarterData, 0)
  294. quarterMap := make(map[int][]*edbDataModel.EdbDataList)
  295. var quarterArr []int
  296. for _, v := range dataList {
  297. itemDate, err := time.Parse(utils.FormatDate, v.DataTime)
  298. if err != nil {
  299. response.FailMsg("获取失败", "季度指标日期转换失败, Err:"+err.Error()+";DataTime:"+v.DataTime, c)
  300. return
  301. }
  302. year := itemDate.Year()
  303. newItemDate := itemDate.AddDate(currentYear-year, 0, 0)
  304. timestamp := newItemDate.UnixNano() / 1e6
  305. v.DataTimestamp = timestamp
  306. if findVal, ok := quarterMap[year]; !ok {
  307. quarterArr = append(quarterArr, year)
  308. findVal = append(findVal, v)
  309. quarterMap[year] = findVal
  310. } else {
  311. findVal = append(findVal, v)
  312. quarterMap[year] = findVal
  313. }
  314. }
  315. for _, v := range quarterArr {
  316. itemList := quarterMap[v]
  317. quarterItem := new(edbDataModel.QuarterData)
  318. quarterItem.Year = v
  319. quarterItem.DataList = itemList
  320. quarterDataList = append(quarterDataList, quarterItem)
  321. }
  322. item.DataList = quarterDataList
  323. }
  324. } else {
  325. item.DataList = dataList
  326. }
  327. edbList = append(edbList, item)
  328. }
  329. sourceArr = append(sourceArr, "弘则研究")
  330. chartInfo.ChartSource = strings.Join(sourceArr, ",")
  331. // 访问记录-仅普通用户记录
  332. userInfo := user.GetInfoByClaims(c)
  333. ok, _, _ := user.GetAdminByUserInfo(userInfo)
  334. if !ok {
  335. reqMyChartClassifyId := c.DefaultQuery("MyChartClassifyId", "")
  336. myChartClassifyId, _ := strconv.Atoi(reqMyChartClassifyId)
  337. go chart.SaveChartVisitLog(userInfo, chartInfo, myChartClassifyId)
  338. }
  339. resp := new(chart_info.ChartInfoDetailResp)
  340. resp.ChartInfo = chartInfo
  341. resp.EdbInfoList = edbList
  342. response.OkData("获取成功", resp, c)
  343. }
  344. // RefreshChartInfo 刷新图表信息
  345. // @Tags 图库模块
  346. // @Summary 刷新图表信息
  347. // @Description 刷新图表信息
  348. // @Security ApiKeyAuth
  349. // @Param Authorization header string true "Bearer 31a165baebe6dec616b1f8f3207b4273"
  350. // @Accept json
  351. // @Product json
  352. // @Param data body chartInfoModel.SaveChartInfoReq true "请求参数"
  353. // @Success 200 {string} string "操作成功"
  354. // @failure 400 {string} string "操作失败"
  355. // @Router /my_chart/refreshChartInfo [post]
  356. func RefreshChartInfo(c *gin.Context) {
  357. // 参数校验
  358. var req chartInfoModel.RefreshChartInfoReq
  359. if c.ShouldBind(&req) != nil {
  360. response.Fail("参数异常", c)
  361. return
  362. }
  363. chartInfoId := req.ChartInfoId
  364. if chartInfoId == 0 {
  365. response.Fail("参数有误", c)
  366. return
  367. }
  368. userInfo := user.GetInfoByClaims(c)
  369. ok, _, err := user.GetAdminByUserInfo(userInfo)
  370. if err != nil {
  371. response.FailMsg("刷新失败", "RefreshChartInfo-获取系统用户信息失败"+err.Error(), c)
  372. return
  373. }
  374. if !ok {
  375. // 普通用户刷新频率限制-每个用户/图/天/2次
  376. cacheKey := utils.HZ_CHART_LIB_DETAIL + "YB_REFRESH_LIMIT_" + strconv.Itoa(chartInfoId) + "_" + strconv.Itoa(int(userInfo.UserID))
  377. fmt.Println("refreshCacheKey:", cacheKey)
  378. countUserRefresh, _ := global.Redis.Get(context.TODO(), cacheKey).Int()
  379. if countUserRefresh >= 2 {
  380. response.Ok("目前已是最新数据", c)
  381. return
  382. }
  383. countUserRefresh += 1
  384. now := time.Now()
  385. today := time.Date(now.Year(), now.Month(), now.Day(), 23, 59, 59, 0, time.Local)
  386. sub := today.Sub(now)
  387. _ = global.Redis.SetEX(context.TODO(), cacheKey, countUserRefresh, sub)
  388. }
  389. // 图表信息校验
  390. chartInfo, err := chartInfoModel.GetChartInfoById(chartInfoId)
  391. if err != nil {
  392. if err == utils.ErrNoRow {
  393. response.Fail("图表已被删除,无需刷新", c)
  394. return
  395. }
  396. response.FailMsg("刷新失败", "刷新失败, Err:"+err.Error(), c)
  397. return
  398. }
  399. // 刷新图表
  400. if err = chart.RefreshChart(chartInfo.ChartInfoId); err != nil {
  401. errContent := fmt.Sprint("ErrMsg: 刷新图表关联指标信息失败, " + err.Error())
  402. if global.CONFIG.Serve.RunMode == "release" {
  403. go alarm_msg.SendAlarmMsg("刷新图表报错"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+errContent, 3)
  404. //go services.SendEmail("弘则研报小程序-release-刷新图表报错", errContent, utils.EmailSendToUsers)
  405. } else {
  406. global.LOG.Info(errContent)
  407. }
  408. }
  409. //清除图表缓存
  410. {
  411. key := utils.HZ_CHART_LIB_DETAIL + chartInfo.UniqueCode
  412. _ = global.Redis.Del(context.TODO(), key)
  413. }
  414. response.OkData("刷新成功", "", c)
  415. }
  416. // EditChartInfo 编辑图表信息
  417. // @Tags 图库模块
  418. // @Summary 编辑图表信息
  419. // @Description 编辑图表信息
  420. // @Security ApiKeyAuth
  421. // @Param Authorization header string true "Bearer 31a165baebe6dec616b1f8f3207b4273"
  422. // @Accept json
  423. // @Product json
  424. // @Param data body chartInfoModel.SaveChartInfoReq true "请求参数"
  425. // @Success 200 {string} string "操作成功"
  426. // @failure 400 {string} string "操作失败"
  427. // @Router /my_chart/editChartInfo [post]
  428. func EditChartInfo(c *gin.Context) {
  429. // 参数校验
  430. var req chartInfoModel.SaveChartInfoReq
  431. if c.ShouldBind(&req) != nil {
  432. response.Fail("参数异常", c)
  433. return
  434. }
  435. if req.ChartInfoId > 0 && len(req.ChartEdbInfoList) <= 0 {
  436. response.Fail("参数异常", c)
  437. return
  438. }
  439. // 操作权限校验
  440. userInfo := user.GetInfoByClaims(c)
  441. ok, adminInfo, err := user.GetAdminByUserInfo(userInfo)
  442. if err != nil {
  443. response.Fail("操作人信息有误", c)
  444. return
  445. }
  446. if !ok {
  447. response.Fail("非内部人员无权进行操作", c)
  448. return
  449. }
  450. // 图表信息校验
  451. chartItem, err := chartInfoModel.GetChartInfoById(req.ChartInfoId)
  452. if err != nil {
  453. if err == utils.ErrNoRow {
  454. response.Fail("图表已被删除,请刷新页面!", c)
  455. return
  456. }
  457. response.FailMsg("操作失败", "获取图表信息失败, Err:"+err.Error(), c)
  458. return
  459. }
  460. if chartItem.ChartType == 2 && len(req.ChartEdbInfoList) > 1 {
  461. response.Fail("您选择的图表样式为季节性图表,只支持单指标画图!", c)
  462. return
  463. }
  464. if req.Calendar == "" {
  465. req.Calendar = "公历"
  466. }
  467. // 指标信息
  468. var edbInfoIdArr []int
  469. edbList := make([]*edbInfoModel.EdbInfo, 0)
  470. for _, v := range req.ChartEdbInfoList {
  471. edbInfo, err := edbInfoModel.GetEdbInfoById(v.EdbInfoId)
  472. if err != nil {
  473. if err == utils.ErrNoRow {
  474. response.FailMsg("操作失败", "图表不存在,ChartInfoId:"+strconv.Itoa(v.EdbInfoId), c)
  475. return
  476. }
  477. response.FailMsg("操作失败", "获取图表的指标信息失败,Err:"+err.Error(), c)
  478. return
  479. }
  480. if edbInfo == nil {
  481. response.FailMsg("操作失败", "指标不存在,ChartInfoId:"+strconv.Itoa(v.EdbInfoId), c)
  482. return
  483. }
  484. edbInfoIdArr = append(edbInfoIdArr, v.EdbInfoId)
  485. edbInfo.EdbNameSource = edbInfo.EdbName
  486. edbList = append(edbList, edbInfo)
  487. }
  488. sort.Ints(edbInfoIdArr)
  489. var edbInfoIdArrStr []string
  490. for _, v := range edbInfoIdArr {
  491. edbInfoIdArrStr = append(edbInfoIdArrStr, strconv.Itoa(v))
  492. }
  493. edbInfoIdStr := strings.Join(edbInfoIdArrStr, ",")
  494. err = chart.ModifyChartInfoAndMapping(edbInfoIdStr, &req, chartItem.ChartType)
  495. if err != nil {
  496. response.Fail("图表保存失败, Err:"+err.Error(), c)
  497. return
  498. }
  499. // 清除图表缓存
  500. cacheKey := utils.HZ_CHART_LIB_DETAIL + chartItem.UniqueCode
  501. _ = global.Redis.Del(context.TODO(), cacheKey)
  502. // 新增操作日志
  503. {
  504. chartLog := new(chart_info_log.ChartInfoLog)
  505. chartLog.ChartName = chartItem.ChartName
  506. chartLog.ChartInfoId = req.ChartInfoId
  507. chartLog.ChartClassifyId = chartItem.ChartClassifyId
  508. chartLog.SysUserId = int(adminInfo.AdminID)
  509. chartLog.SysUserRealName = adminInfo.RealName
  510. chartLog.UniqueCode = chartItem.UniqueCode
  511. chartLog.CreateTime = time.Now()
  512. bodyBytes, _ := ioutil.ReadAll(c.Request.Body)
  513. chartLog.Content = string(bodyBytes)
  514. chartLog.Status = "修改配置项"
  515. chartLog.Method = c.Request.URL.String()
  516. go chartLog.Create()
  517. }
  518. response.OkData("操作成功", "", c)
  519. }