chart_edb_mapping.go 2.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243
  1. package models
  2. import (
  3. "github.com/beego/beego/v2/client/orm"
  4. "hongze/hongze_chart_lib/utils"
  5. )
  6. // GetEtaEdbChartEdbMapping 商品曲线图查询对应的普通指标
  7. func GetEtaEdbChartEdbMapping(chartInfoId int) (item *ChartEdbInfoMapping, err error) {
  8. o := orm.NewOrmUsingDB("data")
  9. 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`
  10. 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.latest_date,b.latest_value,b.unique_code,b.edb_info_type AS edb_info_category_type
  11. FROM chart_edb_mapping AS a
  12. INNER JOIN edb_info AS b ON a.edb_info_id=b.edb_info_id
  13. WHERE a.chart_info_id=? AND a.source = ?
  14. ORDER BY chart_edb_mapping_id ASC `
  15. err = o.Raw(sql, chartInfoId, utils.CHART_SOURCE_DEFAULT).QueryRow(&item)
  16. return
  17. }
  18. // GetFutureGoodEdbChartEdbMapping 商品曲线图查询对应的商品指标
  19. func GetFutureGoodEdbChartEdbMapping(chartInfoId int) (item *ChartEdbInfoMapping, err error) {
  20. o := orm.NewOrmUsingDB("data")
  21. 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`
  22. sql := ` SELECT ` + aField + `,b.future_good_edb_info_id,b.future_good_edb_code as edb_code,b.future_good_edb_name as edb_name,b.start_date,b.end_date,b.modify_time,b.latest_date,b.latest_value
  23. FROM chart_edb_mapping AS a
  24. INNER JOIN future_good_edb_info AS b ON a.edb_info_id=b.future_good_edb_info_id
  25. WHERE a.chart_info_id=? AND a.source = ?
  26. ORDER BY chart_edb_mapping_id ASC `
  27. err = o.Raw(sql, chartInfoId, utils.CHART_SOURCE_FUTURE_GOOD).QueryRow(&item)
  28. return
  29. }
  30. // GetChartEdbMappingByEdbInfoId 根据指标id获取edb_mapping
  31. func GetChartEdbMappingByEdbInfoId(edbInfoId int) (item *ChartEdbInfoMapping, err error) {
  32. o := orm.NewOrmUsingDB("data")
  33. sql := ` SELECT edb_info_id,source_name,source,edb_code,edb_name,edb_name_en,frequency,unit,unit_en,start_date,end_date,modify_time,latest_date,latest_value,unique_code,edb_info_type AS edb_info_category_type,max_value,min_value
  34. FROM edb_info
  35. WHERE edb_info_id = ? limit 1`
  36. err = o.Raw(sql, edbInfoId).QueryRow(&item)
  37. return
  38. }