123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126 |
- package data_manage
- import (
- "eta/eta_api/global"
- "eta/eta_api/utils"
- "time"
- )
- type EdbDataWind struct {
-
- EdbDataId int `gorm:"column:edb_data_id;primaryKey"`
- EdbInfoId int
- EdbCode string
- DataTime string
- Value float64
- Status int
- CreateTime time.Time
- ModifyTime time.Time
- DataTimestamp int64
- }
- func AddEdbDataWindBySql(sqlStr string) (err error) {
-
-
- err = global.DbMap[utils.DbNameIndex].Exec(sqlStr).Error
- return
- }
- func DeleteEdbDataWind(edbCode string) (err error) {
-
- sql := `DELETE FROM edb_data_wind WHERE edb_code=? `
-
- err = global.DbMap[utils.DbNameIndex].Exec(sql, edbCode).Error
- return
- }
- func ModifyEdbDataWind(edbInfoId int64, dataTime string, value float64) (err error) {
-
- sql := ` UPDATE edb_data_wind SET value=?,modify_time=NOW() WHERE edb_info_id=? AND data_time=? `
-
- err = global.DbMap[utils.DbNameIndex].Exec(sql, value, edbInfoId, dataTime).Error
- return
- }
- func GetEdbDataWindByCode(edbCode string, size int) (items []*EdbInfoSearchData, err error) {
-
- sql := ` SELECT * FROM edb_data_wind WHERE edb_code=? ORDER BY data_time DESC LIMIT ? `
-
- err = global.DbMap[utils.DbNameIndex].Raw(sql, edbCode, size).Find(&items).Error
- return
- }
- func GetEdbDataWindMaxOrMinDate(edbCode string) (min_date, max_date string, err error) {
-
-
-
- sql := ` SELECT MIN(data_time) AS minDate,MAX(data_time) AS maxDate FROM edb_data_wind WHERE edb_code=? `
- var maxAndMinDate MaxAndMinDate
- err = global.DbMap[utils.DbNameIndex].Raw(sql, edbCode).First(&maxAndMinDate).Error
- if err != nil {
- return
- }
- min_date = maxAndMinDate.MinDate.Format(utils.FormatDate)
- max_date = maxAndMinDate.MaxDate.Format(utils.FormatDate)
- return
- }
- func GetEdbDataWindByCodeAndDate(edbCode string, startDate string) (count int, err error) {
-
- sql := ` SELECT COUNT(1) AS count FROM edb_data_wind WHERE edb_code=? AND data_time=? `
-
- err = global.DbMap[utils.DbNameIndex].Raw(sql, edbCode, startDate).First(&count).Error
- return
- }
- type EdbDataFromWind struct {
- Close map[string]float64 `json:"CLOSE"`
- Dt map[string]int64 `json:"DT"`
- ErrMsg string
- }
- func EdbInfoUpdateStatusByEdbInfoId(edbInfoIds []int, isStop int, calculateEdbInfoIds []int) (err error) {
-
- o := global.DbMap[utils.DbNameIndex].Begin()
- if err != nil {
- return
- }
- defer func() {
- if err != nil {
- _ = o.Rollback()
- return
- }
- _ = o.Commit()
- }()
-
- if len(edbInfoIds) == 1 {
- sql := ` UPDATE edb_info SET no_update = ?, set_update_time=? WHERE edb_info_id=? `
-
- err = o.Exec(sql, isStop, time.Now(), edbInfoIds[0]).Error
- if err != nil {
- return
- }
- } else {
-
-
- sql := ` UPDATE edb_info SET no_update = ?, set_update_time=? WHERE edb_info_id IN ? `
- err = o.Exec(sql, isStop, time.Now(), edbInfoIds).Error
- if err != nil {
- return
- }
- }
- if len(calculateEdbInfoIds) > 0 {
-
-
-
- sql := ` UPDATE edb_info SET no_update = ?, set_update_time=? WHERE edb_info_id IN ? `
- err = o.Exec(sql, isStop, time.Now(), calculateEdbInfoIds).Error
- if err != nil {
- return
- }
- }
- return
- }
|