chart.go 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619
  1. package models
  2. import (
  3. "errors"
  4. "eta/eta_chart_lib/utils"
  5. "fmt"
  6. "github.com/beego/beego/v2/client/orm"
  7. "strconv"
  8. "time"
  9. "github.com/nosixtools/solarlunar"
  10. )
  11. type ChartInfo struct {
  12. ChartInfoId int `json:"-" orm:"column(chart_info_id);pk"`
  13. ChartName string `description:"来源名称"`
  14. ChartNameEn string `description:"英文图表名称"`
  15. ChartClassifyId int `json:"-" description:"图表分类id"`
  16. SysUserId int `json:"-"`
  17. SysUserRealName string `json:"-"`
  18. UniqueCode string `description:"图表唯一编码"`
  19. CreateTime time.Time `json:"-"`
  20. ModifyTime time.Time `json:"-"`
  21. DateType int `description:"日期类型:1:00年至今,2:10年至今,3:15年至今,4:年初至今,5:自定义时间"`
  22. StartDate string `description:"自定义开始日期"`
  23. EndDate string `description:"自定义结束日期"`
  24. IsSetName int `description:"设置名称"`
  25. EdbInfoIds string `description:"指标id"`
  26. ChartType int `description:"生成样式:1:曲线图,2:季节性图"`
  27. Calendar string `description:"公历/农历"`
  28. SeasonStartDate string `description:"季节性图开始日期"`
  29. SeasonEndDate string `description:"季节性图开始日期"`
  30. ChartImage string `description:"图表图片"`
  31. BarConfig string `description:"柱方图的配置,json数据" json:"-"`
  32. LeftMin string `description:"图表左侧最小值"`
  33. LeftMax string `description:"图表左侧最大值"`
  34. Source int `description:"1:ETA图库;2:商品价格曲线"`
  35. UnitEn string `description:"英文图表单位"`
  36. Unit string `description:"图表单位"`
  37. ExtraConfig string `description:"图表额外配置,json数据" json:"-"`
  38. ChartSource string `description:"图表来源str"`
  39. ChartSourceEn string `description:"图表来源(英文)"`
  40. SeasonExtraConfig string `description:"季节性图表中的配置,json数据"`
  41. StartYear int `description:"当选择的日期类型为最近N年类型时,即date_type=20, 用start_year表示N"`
  42. ChartThemeId int `description:"图表应用主题ID"`
  43. ChartThemeStyle string `description:"图表应用主题样式"`
  44. SourcesFrom string `description:"图表来源"`
  45. Instructions string `description:"图表说明"`
  46. MarkersLines string `description:"标识线"`
  47. MarkersAreas string `description:"标识区"`
  48. }
  49. func GetChartInfoByUniqueCode(uniqueCode string) (item *ChartInfo, err error) {
  50. o := orm.NewOrmUsingDB("data")
  51. sql := ` SELECT * FROM chart_info WHERE unique_code=? `
  52. err = o.Raw(sql, uniqueCode).QueryRow(&item)
  53. return
  54. }
  55. type ChartEdbInfoMapping struct {
  56. EdbInfoId int `description:"指标id"`
  57. SourceName string `description:"来源名称"`
  58. Source int `description:"来源id"`
  59. EdbCode string `description:"指标编码"`
  60. EdbName string `description:"指标名称"`
  61. EdbAliasName string `description:"指标名称(别名)"`
  62. EdbAliasNameEn string `description:"英文指标名称(别名)"`
  63. EdbNameEn string `description:"英文指标名称"`
  64. Frequency string `description:"频率"`
  65. FrequencyEn string `description:"英文频率"`
  66. Unit string `description:"单位"`
  67. UnitEn string `description:"英文单位"`
  68. StartDate string `description:"起始日期"`
  69. EndDate string `description:"终止日期"`
  70. ModifyTime string `description:"指标最后更新时间"`
  71. ChartEdbMappingId int `description:"图表指标id" json:"-"`
  72. ChartInfoId int `description:"图表id"`
  73. MaxData float64 `description:"上限"`
  74. MinData float64 `description:"下限"`
  75. IsOrder bool `description:"true:正序,false:逆序"`
  76. IsAxis int `description:"1:左轴,0:右轴"`
  77. EdbInfoType int `description:"1:标准指标,0:领先指标"`
  78. EdbType int `description:"指标类型:1:基础指标,2:计算指标"`
  79. LeadValue int `description:"领先值"`
  80. LeadUnit string `description:"领先单位"`
  81. LeadUnitEn string `description:"领先英文单位"`
  82. ChartStyle string `description:"图表类型"`
  83. ChartColor string `description:"颜色"`
  84. ChartWidth float64 `description:"线条大小"`
  85. DataList interface{}
  86. EdbInfoCategoryType int `description:"0:普通指标,1:预测指标"`
  87. PredictChartColor string `description:"预测数据的颜色"`
  88. ChartType int `description:"生成样式:1:曲线图,2:季节性图,3:面积图,4:柱状图,5:散点图,6:组合图"`
  89. LatestDate string `description:"数据最新日期"`
  90. LatestValue float64 `description:"数据最新值"`
  91. MoveLatestDate string `description:"移动后的数据最新日期"`
  92. UniqueCode string `description:"指标唯一编码"`
  93. MinValue float64 `json:"-" description:"最小值"`
  94. MaxValue float64 `json:"-" description:"最大值"`
  95. IsNullData bool `json:"-" description:"是否空数据"`
  96. MappingSource int `description:"1:ETA图库;2:商品价格曲线"`
  97. SubSource int `description:"子数据来源:0:经济数据库,1:日期序列"`
  98. SubSourceName string `description:"子数据来源名称"`
  99. IndicatorCode string `description:"指标代码"`
  100. StockCode string `description:"证券代码"`
  101. }
  102. func GetChartEdbMappingList(chartInfoId int) (list []*ChartEdbInfoMapping, err error) {
  103. o := orm.NewOrmUsingDB("data")
  104. aField := `a.chart_edb_mapping_id,a.chart_info_id,a.edb_info_id,a.create_time,a.modify_time,a.unique_code,a.max_data,a.min_data,a.is_order,a.is_axis,a.edb_info_type,a.lead_value,a.lead_unit,a.chart_style,a.chart_color,a.predict_chart_color,a.chart_width,a.source as mapping_source`
  105. sql := ` SELECT ` + aField + `,b.source_name,b.source,b.edb_code,b.edb_name,b.edb_name_en,b.frequency,b.unit,b.unit_en,b.start_date,b.end_date,b.modify_time,b.edb_type,b.latest_date,b.latest_value,b.unique_code,b.edb_info_type AS edb_info_category_type,b.sub_source
  106. FROM chart_edb_mapping AS a
  107. INNER JOIN edb_info AS b ON a.edb_info_id=b.edb_info_id
  108. WHERE chart_info_id=?
  109. ORDER BY chart_edb_mapping_id ASC `
  110. _, err = o.Raw(sql, chartInfoId).QueryRows(&list)
  111. return
  112. }
  113. type EdbDataList struct {
  114. EdbDataId int `json:"-" description:" 指标数据ID"`
  115. EdbInfoId int `json:"-" description:"指标ID"`
  116. DataTime string `json:"-" description:"数据日期"`
  117. DataTimestamp int64 `description:"数据日期"`
  118. Value float64 `description:"数据值"`
  119. }
  120. // GetEdbDataList 获取指标的数据(日期正序返回)
  121. func GetEdbDataList(source, subSource, endInfoId int, startDate, endDate string) (list []*EdbDataList, err error) {
  122. tableName := GetEdbDataTableName(source, subSource)
  123. if tableName == "" {
  124. err = errors.New("无效的渠道:" + strconv.Itoa(source))
  125. list = make([]*EdbDataList, 0)
  126. return list, err
  127. }
  128. var pars []interface{}
  129. var condition string
  130. if startDate != "" {
  131. condition += ` AND data_time>=? `
  132. pars = append(pars, startDate)
  133. }
  134. if endDate != "" {
  135. condition += ` AND data_time<=? `
  136. pars = append(pars, endDate)
  137. }
  138. sql := `SELECT edb_data_id,edb_info_id,data_time,TRUNCATE(value,4) AS value,data_timestamp FROM %s WHERE edb_info_id=? `
  139. if condition != "" {
  140. sql += condition
  141. }
  142. sql += ` ORDER BY data_time ASC `
  143. sql = fmt.Sprintf(sql, tableName)
  144. o := orm.NewOrmUsingDB("data")
  145. _, err = o.Raw(sql, endInfoId, pars).QueryRows(&list)
  146. return
  147. }
  148. type EdbDataItemList struct {
  149. EdbDataId int `json:"-" description:" 指标数据ID"`
  150. EdbInfoId int `json:"-" description:"指标ID"`
  151. DataTime string `description:"数据日期"`
  152. DataTimestamp int64 `description:"数据日期"`
  153. Value float64 `description:"数据值"`
  154. }
  155. type EdbDataItems struct {
  156. Items []*EdbDataList
  157. Year int
  158. BetweenDay int `json:"-" description:"公历与农历之间相差的天数"`
  159. CuttingDataTimestamp int64 `description:"切割的时间戳"`
  160. }
  161. type EdbDataResult struct {
  162. List []*EdbDataItems
  163. }
  164. type QuarterData struct {
  165. Year string
  166. DataList []*EdbDataList
  167. CuttingDataTimestamp int64 `description:"切割的时间戳"`
  168. ChartLegend string
  169. Years string
  170. }
  171. type QuarterXDateItem struct {
  172. StartDate time.Time
  173. EndDate time.Time
  174. ShowName string
  175. ChartLegend string
  176. CuttingDataTimestamp int64 `description:"切割的时间戳"`
  177. }
  178. type ChartInfoDetailResp struct {
  179. ChartInfo *ChartInfo
  180. EdbInfoList []*ChartEdbInfoMapping
  181. XEdbIdValue []int `description:"柱方图的x轴数据,指标id"`
  182. YDataList []YData `description:"柱方图的y轴数据"`
  183. XDataList []XData `description:"商品价格曲线的X轴数据"`
  184. CorrelationChartInfo *CorrelationInfo `description:"相关性图表信息"`
  185. DataResp interface{} `description:"图表数据,根据图的类型而定的,没有确定的数据格式"`
  186. WaterMark string `description:"水印"`
  187. }
  188. // XData 商品价格曲线的的x轴数据
  189. type XData struct {
  190. Name string `description:"别名"`
  191. NameEn string `description:"英文别名"`
  192. }
  193. // YData 柱方图的y轴数据
  194. type YData struct {
  195. Date string `description:"数据日期"`
  196. ConfigDate time.Time `description:"配置的日期" json:"-"`
  197. Color string `description:"数据颜色"`
  198. Name string `description:"别名"`
  199. NameEn string `description:"英文别名"`
  200. Value []float64 `description:"每个指标的值"`
  201. NoDataEdbList []int `description:"没有数据的指标列表"`
  202. XEdbInfoIdList []int `description:"对应X轴的指标id列表"`
  203. EdbValMap map[int]float64 `description:"指标与值的对应" json:"-"`
  204. M []int `description:"对应开始日期的间隔值" json:"-"`
  205. NameList []string `description:"每个值对应的名称"`
  206. EnNameList []string `description:"每个值对应的英文名称"`
  207. Unit string `description:"中文单位名称"`
  208. UnitEn string `description:"英文单位名称"`
  209. }
  210. // RollingCorrelationChartDataResp 滚动相关性图
  211. type RollingCorrelationChartDataResp struct {
  212. XDateTimeValue []string `description:"滚动相关性图的x轴数据,日期数据"`
  213. YDataList []YData `description:"滚动相关性图的y轴数据"`
  214. }
  215. // 指标季度数据计算(公历转农历)
  216. func AddCalculateQuarterV5(dataList []*EdbDataList) (result *EdbDataResult, err error) {
  217. var errMsg string
  218. defer func() {
  219. if errMsg != "" {
  220. fmt.Println("errMsg:", errMsg)
  221. }
  222. }()
  223. if len(dataList) <= 0 {
  224. result.List = make([]*EdbDataItems, 0)
  225. return
  226. }
  227. endDate := dataList[len(dataList)-1].DataTime
  228. endDateForm, err := time.Parse(utils.FormatDate, endDate)
  229. if err != nil {
  230. return result, err
  231. }
  232. thisMonth := int(endDateForm.Month())
  233. result = new(EdbDataResult)
  234. var yearArr []int
  235. yearMap := make(map[int]int)
  236. var cureentDate time.Time
  237. if thisMonth < 11 {
  238. for k, v := range dataList {
  239. dateTime, err := time.Parse(utils.FormatDate, v.DataTime)
  240. if err != nil {
  241. errMsg = "time.Parse Err:" + err.Error() + ";DataTime:" + v.DataTime
  242. return result, err
  243. }
  244. if k == len(dataList)-1 {
  245. cureentDate = dateTime
  246. }
  247. year := dateTime.Year()
  248. if _, ok := yearMap[year]; !ok {
  249. yearArr = append(yearArr, year)
  250. }
  251. yearMap[year] = year
  252. }
  253. } else {
  254. for k, v := range dataList {
  255. dateTime, err := time.Parse(utils.FormatDate, v.DataTime)
  256. if err != nil {
  257. errMsg = "time.Parse Err:" + err.Error() + ";DataTime:" + v.DataTime
  258. return result, err
  259. }
  260. if k == len(dataList)-1 {
  261. cureentDate = dateTime
  262. }
  263. year := dateTime.Year() + 1
  264. if _, ok := yearMap[year]; !ok {
  265. yearArr = append(yearArr, year)
  266. }
  267. yearMap[year] = year
  268. }
  269. }
  270. //排序
  271. fmt.Println("yearArr:", yearArr)
  272. thisYear := cureentDate.Year()
  273. //thisMonth := int(cureentDate.Month())
  274. fmt.Println("thisMonth:", thisMonth)
  275. for ky, vy := range yearArr {
  276. fmt.Println("line 432:", ky, vy, thisYear, thisMonth)
  277. if thisMonth < 11 {
  278. currentYearCjnl := strconv.Itoa(thisYear) + "-01-01" //当前年份春节农历
  279. currentYearCjgl := solarlunar.LunarToSolar(currentYearCjnl, false) //当前年份春节公历
  280. currentYearCjglDate, err := time.Parse(utils.FormatDate, currentYearCjgl)
  281. if err != nil {
  282. errMsg = "生成当前春节失败,Err:" + err.Error()
  283. return result, err
  284. }
  285. preYear := vy
  286. preYearCjnl := strconv.Itoa(preYear) + "-01-01" //之前年份春节农历
  287. preYearCjgl := solarlunar.LunarToSolar(preYearCjnl, false) //之前年份春节公历
  288. preYearCjglDate, err := time.Parse(utils.FormatDate, preYearCjgl)
  289. if err != nil {
  290. errMsg = "生成历史年份春节失败,Err:" + err.Error()
  291. return result, err
  292. }
  293. day := currentYearCjglDate.Sub(preYearCjglDate).Hours() / float64(24)
  294. items := new(EdbDataItems)
  295. items.BetweenDay = int(day) //公历日期换算成农历,需要减除的天数
  296. items.Year = preYear
  297. for _, v := range dataList {
  298. dateTime, err := time.Parse(utils.FormatDate, v.DataTime)
  299. if err != nil {
  300. errMsg = "time.Parse Err:" + err.Error() + ";DataTime:" + v.DataTime
  301. return result, err
  302. }
  303. newDate := dateTime.AddDate(0, 0, int(day))
  304. selectDateStr := strconv.Itoa(thisYear) + "-11" + "-30"
  305. selectDate, _ := time.Parse(utils.FormatDate, selectDateStr)
  306. if newDate.Before(selectDate) || newDate == selectDate {
  307. timestamp := newDate.UnixNano() / 1e6
  308. item := new(EdbDataList)
  309. item.DataTime = newDate.Format(utils.FormatDate)
  310. item.EdbInfoId = v.EdbInfoId
  311. item.Value = v.Value
  312. item.EdbDataId = v.EdbDataId
  313. item.DataTimestamp = timestamp
  314. items.Items = append(items.Items, item)
  315. }
  316. }
  317. result.List = append(result.List, items)
  318. } else {
  319. nextYear := thisYear + 1
  320. nextYearCjnl := strconv.Itoa(nextYear) + "-01-01" //当前年份春节农历
  321. nextYearCjgl := solarlunar.LunarToSolar(nextYearCjnl, false) //当前年份春节公历
  322. nextYearCjglDate, err := time.Parse(utils.FormatDate, nextYearCjgl)
  323. if err != nil {
  324. errMsg = "生成当前春节失败,Err:" + err.Error()
  325. return result, err
  326. }
  327. preYear := vy
  328. preYearCjnl := strconv.Itoa(preYear) + "-01-01" //之前年份春节农历
  329. preYearCjgl := solarlunar.LunarToSolar(preYearCjnl, false) //之前年份春节公历
  330. preYearCjglDate, err := time.Parse(utils.FormatDate, preYearCjgl)
  331. if err != nil {
  332. errMsg = "生成历史年份春节失败,Err:" + err.Error()
  333. return result, err
  334. }
  335. day := nextYearCjglDate.Sub(preYearCjglDate).Hours() / float64(24)
  336. fmt.Println("day:", day, nextYearCjglDate, preYearCjglDate)
  337. items := new(EdbDataItems)
  338. items.BetweenDay = int(day) //公历日期换算成农历,需要减除的天数
  339. items.Year = preYear - 1
  340. fmt.Println("preYear:", preYear, "ky:", ky, "yearArrLen:", len(yearArr))
  341. if ky+1 < len(yearArr) {
  342. for _, v := range dataList {
  343. dateTime, err := time.Parse(utils.FormatDate, v.DataTime)
  344. if err != nil {
  345. errMsg = "time.Parse Err:" + err.Error() + ";DataTime:" + v.DataTime
  346. return result, err
  347. }
  348. newDate := dateTime.AddDate(0, 0, int(day))
  349. selectDateStr := strconv.Itoa(nextYear) + "-05" + "-31"
  350. selectDate, _ := time.Parse(utils.FormatDate, selectDateStr)
  351. if newDate.Before(selectDate) || newDate == selectDate {
  352. timestamp := newDate.UnixNano() / 1e6
  353. item := new(EdbDataList)
  354. item.DataTime = newDate.Format(utils.FormatDate)
  355. item.EdbInfoId = v.EdbInfoId
  356. item.Value = v.Value
  357. item.EdbDataId = v.EdbDataId
  358. item.DataTimestamp = timestamp
  359. items.Items = append(items.Items, item)
  360. }
  361. }
  362. result.List = append(result.List, items)
  363. } else {
  364. for _, v := range dataList {
  365. dateTime, err := time.Parse(utils.FormatDate, v.DataTime)
  366. if err != nil {
  367. errMsg = "time.Parse Err:" + err.Error() + ";DataTime:" + v.DataTime
  368. return result, err
  369. }
  370. timestamp := dateTime.UnixNano() / 1e6
  371. item := new(EdbDataList)
  372. item.DataTime = dateTime.Format(utils.FormatDate)
  373. item.EdbInfoId = v.EdbInfoId
  374. item.Value = v.Value
  375. item.EdbDataId = v.EdbDataId
  376. item.DataTimestamp = timestamp
  377. items.Items = append(items.Items, item)
  378. }
  379. result.List = append(result.List, items)
  380. }
  381. }
  382. }
  383. return
  384. }
  385. // AddCalculateQuarterV6 指标季度数据计算(季节性图表)
  386. func AddCalculateQuarterV6(dataList []*EdbDataList) (result *EdbDataResult, err error) {
  387. var errMsg string
  388. defer func() {
  389. if errMsg != "" {
  390. fmt.Println("errMsg:", errMsg)
  391. }
  392. }()
  393. endDate := dataList[len(dataList)-1].DataTime
  394. endDateForm, err := time.Parse(utils.FormatDate, endDate)
  395. if err != nil {
  396. return result, err
  397. }
  398. thisMonth := int(endDateForm.Month())
  399. result = new(EdbDataResult)
  400. var yearArr []int
  401. yearMap := make(map[int]int)
  402. var cureentDate time.Time
  403. if thisMonth < 11 {
  404. for k, v := range dataList {
  405. dateTime, err := time.Parse(utils.FormatDate, v.DataTime)
  406. if err != nil {
  407. errMsg = "time.Parse Err:" + err.Error() + ";DataTime:" + v.DataTime
  408. return result, err
  409. }
  410. if k == len(dataList)-1 {
  411. cureentDate = dateTime
  412. }
  413. year := dateTime.Year()
  414. if _, ok := yearMap[year]; !ok {
  415. yearArr = append(yearArr, year)
  416. }
  417. yearMap[year] = year
  418. }
  419. } else {
  420. for k, v := range dataList {
  421. dateTime, err := time.Parse(utils.FormatDate, v.DataTime)
  422. if err != nil {
  423. errMsg = "time.Parse Err:" + err.Error() + ";DataTime:" + v.DataTime
  424. return result, err
  425. }
  426. if k == len(dataList)-1 {
  427. cureentDate = dateTime
  428. }
  429. year := dateTime.Year() + 1
  430. if _, ok := yearMap[year]; !ok {
  431. yearArr = append(yearArr, year)
  432. }
  433. yearMap[year] = year
  434. }
  435. }
  436. //排序
  437. fmt.Println("yearArr:", yearArr)
  438. thisYear := cureentDate.Year()
  439. //thisMonth := int(cureentDate.Month())
  440. fmt.Println("thisMonth:", thisMonth)
  441. for ky, vy := range yearArr {
  442. fmt.Printf("line 432:ky:%d, vy:%d, thisYear:%d, thisMonth:%d", ky, vy, thisYear, thisMonth)
  443. fmt.Println("")
  444. if thisMonth < 11 {
  445. currentYearCjnl := strconv.Itoa(thisYear) + "-01-01" //当前年份春节农历
  446. currentYearCjgl := solarlunar.LunarToSolar(currentYearCjnl, false) //当前年份春节公历
  447. currentYearCjglDate, err := time.Parse(utils.FormatDate, currentYearCjgl)
  448. if err != nil {
  449. errMsg = "生成当前春节失败,Err:" + err.Error()
  450. return result, err
  451. }
  452. preYear := vy
  453. preYearCjnl := strconv.Itoa(preYear) + "-01-01" //之前年份春节农历
  454. preYearCjgl := solarlunar.LunarToSolar(preYearCjnl, false) //之前年份春节公历
  455. preYearCjglDate, err := time.Parse(utils.FormatDate, preYearCjgl)
  456. if err != nil {
  457. errMsg = "生成历史年份春节失败,Err:" + err.Error()
  458. return result, err
  459. }
  460. day := currentYearCjglDate.Sub(preYearCjglDate).Hours() / float64(24)
  461. fmt.Println("day:", day, currentYearCjglDate, preYearCjglDate)
  462. items := new(EdbDataItems)
  463. items.BetweenDay = int(day) //公历日期换算成农历,需要减除的天数
  464. items.Year = preYear
  465. for _, v := range dataList {
  466. dateTime, err := time.Parse(utils.FormatDate, v.DataTime)
  467. if err != nil {
  468. errMsg = "time.Parse Err:" + err.Error() + ";DataTime:" + v.DataTime
  469. return result, err
  470. }
  471. newDate := dateTime.AddDate(0, 0, int(day))
  472. timestamp := newDate.UnixNano() / 1e6
  473. item := new(EdbDataList)
  474. item.DataTime = newDate.Format(utils.FormatDate)
  475. item.EdbInfoId = v.EdbInfoId
  476. item.Value = v.Value
  477. item.EdbDataId = v.EdbDataId
  478. item.DataTimestamp = timestamp
  479. items.Items = append(items.Items, item)
  480. }
  481. result.List = append(result.List, items)
  482. } else {
  483. nextYear := thisYear + 1
  484. nextYearCjnl := strconv.Itoa(nextYear) + "-01-01" //当前年份春节农历
  485. nextYearCjgl := solarlunar.LunarToSolar(nextYearCjnl, false) //当前年份春节公历
  486. nextYearCjglDate, err := time.Parse(utils.FormatDate, nextYearCjgl)
  487. if err != nil {
  488. errMsg = "生成当前春节失败,Err:" + err.Error()
  489. return result, err
  490. }
  491. preYear := vy
  492. preYearCjnl := strconv.Itoa(preYear) + "-01-01" //之前年份春节农历
  493. preYearCjgl := solarlunar.LunarToSolar(preYearCjnl, false) //之前年份春节公历
  494. preYearCjglDate, err := time.Parse(utils.FormatDate, preYearCjgl)
  495. if err != nil {
  496. errMsg = "生成历史年份春节失败,Err:" + err.Error()
  497. return result, err
  498. }
  499. day := nextYearCjglDate.Sub(preYearCjglDate).Hours() / float64(24)
  500. fmt.Println("day:", day, nextYearCjglDate, preYearCjglDate)
  501. items := new(EdbDataItems)
  502. items.BetweenDay = int(day) //公历日期换算成农历,需要减除的天数
  503. items.Year = preYear
  504. fmt.Println("preYear:", preYear, "ky:", ky, "yearArrLen:", len(yearArr))
  505. //if ky+1 < len(yearArr) {
  506. for _, v := range dataList {
  507. dateTime, err := time.Parse(utils.FormatDate, v.DataTime)
  508. if err != nil {
  509. errMsg = "time.Parse Err:" + err.Error() + ";DataTime:" + v.DataTime
  510. return result, err
  511. }
  512. newDate := dateTime.AddDate(0, 0, int(day))
  513. timestamp := newDate.UnixNano() / 1e6
  514. item := new(EdbDataList)
  515. item.DataTime = newDate.Format(utils.FormatDate)
  516. item.EdbInfoId = v.EdbInfoId
  517. item.Value = v.Value
  518. item.EdbDataId = v.EdbDataId
  519. item.DataTimestamp = timestamp
  520. items.Items = append(items.Items, item)
  521. }
  522. result.List = append(result.List, items)
  523. /*} else {
  524. for _, v := range dataList {
  525. dateTime, err := time.Parse(utils.FormatDate, v.DataTime)
  526. if err != nil {
  527. errMsg = "time.Parse Err:" + err.Error() + ";DataTime:" + v.DataTime
  528. return result, err
  529. }
  530. timestamp := dateTime.UnixNano() / 1e6
  531. item := new(EdbDataList)
  532. item.DataTime = dateTime.Format(utils.FormatDate)
  533. item.EdbInfoId = v.EdbInfoId
  534. item.Value = v.Value
  535. item.EdbDataId = v.EdbDataId
  536. item.DataTimestamp = timestamp
  537. items.Items = append(items.Items, item)
  538. }
  539. result.List = append(result.List, items)
  540. }*/
  541. }
  542. }
  543. return
  544. }
  545. type CorrelationInfo struct {
  546. LeadValue int `description:"领先值"`
  547. LeadUnit string `description:"领先单位"`
  548. StartDate string `description:"开始日期"`
  549. EndDate string `description:"结束日期"`
  550. EdbInfoIdFirst int `description:"A指标ID"`
  551. EdbInfoIdSecond int `description:"B指标ID"`
  552. PeriodData string `description:"X轴-期数数据"`
  553. CorrelationData string `description:"Y轴-相关性系数"`
  554. }
  555. type SeasonExtraItem struct {
  556. ChartLegend []SeasonChartLegend `description:"自定义的图例名称"`
  557. XStartDate string `description:"横坐标显示的起始日"`
  558. XEndDate string `description:"横坐标显示的截止日"`
  559. JumpYear int `description:"横坐标日期是否跨年,1跨年,0不跨年"`
  560. }
  561. type SeasonChartLegend struct {
  562. Name string
  563. Value string
  564. }
  565. type QuarterDataList []*QuarterData
  566. func (m QuarterDataList) Len() int {
  567. return len(m)
  568. }
  569. func (m QuarterDataList) Less(i, j int) bool {
  570. return m[i].Years < m[j].Years
  571. }
  572. func (m QuarterDataList) Swap(i, j int) {
  573. m[i], m[j] = m[j], m[i]
  574. }