chart_info.go 16 KB

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