chart.go 23 KB

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