edb_data_wind.go 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126
  1. package data_manage
  2. import (
  3. "eta/eta_api/global"
  4. "eta/eta_api/utils"
  5. "time"
  6. )
  7. type EdbDataWind struct {
  8. //EdbDataId int `orm:"column(edb_data_id);pk"`
  9. EdbDataId int `gorm:"column:edb_data_id;primaryKey"`
  10. EdbInfoId int
  11. EdbCode string
  12. DataTime string
  13. Value float64
  14. Status int
  15. CreateTime time.Time
  16. ModifyTime time.Time
  17. DataTimestamp int64
  18. }
  19. func AddEdbDataWindBySql(sqlStr string) (err error) {
  20. //o := orm.NewOrmUsingDB("data")
  21. //_, err = o.Raw(sqlStr).Exec()
  22. err = global.DbMap[utils.DbNameIndex].Exec(sqlStr).Error
  23. return
  24. }
  25. func DeleteEdbDataWind(edbCode string) (err error) {
  26. //o := orm.NewOrmUsingDB("data")
  27. sql := `DELETE FROM edb_data_wind WHERE edb_code=? `
  28. //_, err = o.Raw(sql, edbCode).Exec()
  29. err = global.DbMap[utils.DbNameIndex].Exec(sql, edbCode).Error
  30. return
  31. }
  32. func ModifyEdbDataWind(edbInfoId int64, dataTime string, value float64) (err error) {
  33. //o := orm.NewOrmUsingDB("data")
  34. sql := ` UPDATE edb_data_wind SET value=?,modify_time=NOW() WHERE edb_info_id=? AND data_time=? `
  35. //_, err = o.Raw(sql, value, edbInfoId, dataTime).Exec()
  36. err = global.DbMap[utils.DbNameIndex].Exec(sql, value, edbInfoId, dataTime).Error
  37. return
  38. }
  39. func GetEdbDataWindByCode(edbCode string, size int) (items []*EdbInfoSearchData, err error) {
  40. //o := orm.NewOrmUsingDB("data")
  41. sql := ` SELECT * FROM edb_data_wind WHERE edb_code=? ORDER BY data_time DESC LIMIT ? `
  42. //_, err = o.Raw(sql, edbCode, size).QueryRows(&items)
  43. err = global.DbMap[utils.DbNameIndex].Raw(sql, edbCode, size).Find(&items).Error
  44. return
  45. }
  46. func GetEdbDataWindMaxOrMinDate(edbCode string) (min_date, max_date string, err error) {
  47. //o := orm.NewOrmUsingDB("data")
  48. //sql := ` SELECT MIN(data_time) AS min_date,MAX(data_time) AS max_date FROM edb_data_wind WHERE edb_code=? `
  49. //err = o.Raw(sql, edbCode).QueryRow(&min_date, &max_date)
  50. sql := ` SELECT MIN(data_time) AS minDate,MAX(data_time) AS maxDate FROM edb_data_wind WHERE edb_code=? `
  51. var maxAndMinDate MaxAndMinDate
  52. err = global.DbMap[utils.DbNameIndex].Raw(sql, edbCode).First(&maxAndMinDate).Error
  53. if err != nil {
  54. return
  55. }
  56. min_date = maxAndMinDate.MinDate.Format(utils.FormatDate)
  57. max_date = maxAndMinDate.MaxDate.Format(utils.FormatDate)
  58. return
  59. }
  60. func GetEdbDataWindByCodeAndDate(edbCode string, startDate string) (count int, err error) {
  61. //o := orm.NewOrmUsingDB("data")
  62. sql := ` SELECT COUNT(1) AS count FROM edb_data_wind WHERE edb_code=? AND data_time=? `
  63. //err = o.Raw(sql, edbCode, startDate).QueryRow(&count)
  64. err = global.DbMap[utils.DbNameIndex].Raw(sql, edbCode, startDate).First(&count).Error
  65. return
  66. }
  67. type EdbDataFromWind struct {
  68. Close map[string]float64 `json:"CLOSE"`
  69. Dt map[string]int64 `json:"DT"`
  70. ErrMsg string
  71. }
  72. func EdbInfoUpdateStatusByEdbInfoId(edbInfoIds []int, isStop int, calculateEdbInfoIds []int) (err error) {
  73. //o, err := orm.NewOrmUsingDB("data").Begin()
  74. o := global.DbMap[utils.DbNameIndex].Begin()
  75. if err != nil {
  76. return
  77. }
  78. defer func() {
  79. if err != nil {
  80. _ = o.Rollback()
  81. return
  82. }
  83. _ = o.Commit()
  84. }()
  85. // 更改指标的更新状态
  86. if len(edbInfoIds) == 1 {
  87. sql := ` UPDATE edb_info SET no_update = ?, set_update_time=? WHERE edb_info_id=? `
  88. //_, err = o.Raw(sql, isStop, time.Now(), edbInfoIds[0]).Exec()
  89. err = o.Exec(sql, isStop, time.Now(), edbInfoIds[0]).Error
  90. if err != nil {
  91. return
  92. }
  93. } else {
  94. //sql := ` UPDATE edb_info SET no_update = ?, set_update_time=? WHERE edb_info_id IN (` + utils.GetOrmInReplace(len(edbInfoIds)) + `) `
  95. //_, err = o.Raw(sql, isStop, time.Now(), edbInfoIds).Exec()
  96. sql := ` UPDATE edb_info SET no_update = ?, set_update_time=? WHERE edb_info_id IN ? `
  97. err = o.Exec(sql, isStop, time.Now(), edbInfoIds).Error
  98. if err != nil {
  99. return
  100. }
  101. }
  102. if len(calculateEdbInfoIds) > 0 {
  103. // 批量更新相关联的指标ID
  104. //sql := ` UPDATE edb_info SET no_update = ?, set_update_time=? WHERE edb_info_id IN (` + utils.GetOrmInReplace(len(calculateEdbInfoIds)) + `) `
  105. //_, err = o.Raw(sql, isStop, time.Now(), calculateEdbInfoIds).Exec()
  106. sql := ` UPDATE edb_info SET no_update = ?, set_update_time=? WHERE edb_info_id IN ? `
  107. err = o.Exec(sql, isStop, time.Now(), calculateEdbInfoIds).Error
  108. if err != nil {
  109. return
  110. }
  111. }
  112. return
  113. }