chart.go 24 KB

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