edb_data_gie.go 2.9 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495
  1. package data_manage
  2. import (
  3. "eta/eta_api/global"
  4. "eta/eta_api/utils"
  5. "fmt"
  6. "time"
  7. )
  8. type GieData struct {
  9. InputValue string `orm:"column(DATA_VALUE)" description:"日期"`
  10. DataTime string `orm:"column(DATA_DATE)" description:"值"`
  11. }
  12. func GetEdbDataGieMaxOrMinDate(edbCode string) (minDate, maxDate string, err error) {
  13. //o := orm.NewOrmUsingDB("data")
  14. sql := ` SELECT MIN(data_time) AS minDate,MAX(data_time) AS maxDate FROM edb_data_gie WHERE edb_code=? `
  15. //err = o.Raw(sql, edbCode).QueryRow(&minDate, &maxDate)
  16. var maxAndMinDate MaxAndMinDate
  17. err = global.DbMap[utils.DbNameIndex].Raw(sql, edbCode).First(&maxAndMinDate).Error
  18. if err != nil {
  19. return
  20. }
  21. minDate = maxAndMinDate.MinDate.Format(utils.FormatDate)
  22. maxDate = maxAndMinDate.MaxDate.Format(utils.FormatDate)
  23. return
  24. }
  25. type EicIndexV2 struct {
  26. //BaseFromEicIndexId int `orm:"column(base_from_eic_index_id);pk"`
  27. BaseFromEicIndexId int `gorm:"column:base_from_eic_index_id;primaryKey"`
  28. Type string
  29. EicCode string
  30. Name string
  31. Status string
  32. GasDayStart string
  33. GasInStorage string
  34. GasInStorageCode string
  35. Consumption string
  36. ConsumptionCode string
  37. ConsumptionFull string
  38. ConsumptionFullCode string
  39. Full string
  40. FullCode string
  41. Trend string
  42. TrendCode string
  43. Injection string
  44. InjectionCode string
  45. Withdrawal string
  46. WithdrawalCode string
  47. WorkingGasVolume string
  48. WorkingGasVolumeCode string
  49. InjectionCapacity string
  50. InjectionCapacityCode string
  51. WithdrawalCapacity string
  52. WithdrawalCapacityCode string
  53. Info string
  54. Parent string
  55. CreateTime time.Time
  56. ModifyTime time.Time
  57. Children []BaseFromTradeEicIndexV2
  58. }
  59. func GetBaseFromEicDataAllByIndexCodeV2(indexCode, suffix string) (list []*BaseFromTradeEicIndexV2, err error) {
  60. //o := orm.NewOrmUsingDB("data")
  61. var name string
  62. if suffix == "" {
  63. name = "eic_code"
  64. } else if suffix == "GS" {
  65. name = "gas_in_storage_code"
  66. } else if suffix == "C" {
  67. name = "consumption_code"
  68. } else if suffix == "CF" {
  69. name = "consumption_full_code"
  70. } else if suffix == "F" {
  71. name = "full_code"
  72. } else if suffix == "T" {
  73. name = "trend_code"
  74. } else if suffix == "In" {
  75. name = "injection_code"
  76. } else if suffix == "Out" {
  77. name = "withdrawal_code"
  78. } else if suffix == "WGV" {
  79. name = "working_gas_volume_code"
  80. } else if suffix == "IC" {
  81. name = "injection_capacity_code"
  82. } else if suffix == "WC" {
  83. name = "withdrawal_capacity_code"
  84. }
  85. sql := `SELECT * FROM base_from_trade_eic_index_v2 WHERE %s=? `
  86. sql = fmt.Sprintf(sql, name)
  87. //_, err = o.Raw(sql, indexCode).QueryRows(&list)
  88. err = global.DbMap[utils.DbNameIndex].Raw(sql, indexCode).Find(&list).Error
  89. return
  90. }