eta_task/models/data_manage/edb_data_lt.go

package data_manage

//type EdbDataLt struct {
//	EdbDataId     int `orm:"column(edb_data_id);pk" gorm:"primaryKey"`
//	EdbInfoId     int
//	EdbCode       string
//	DataTime      string
//	Value         float64
//	Status        int
//	CreateTime    time.Time
//	ModifyTime    time.Time
//	DataTimestamp int64
//}

// AddEdbDataLtBySql 执行添加数据的sql
//func AddEdbDataLtBySql(sqlStr string) (err error) {
//	o := global.DbMap[utils.DbNameIndex]
//	err = o.Exec(sqlStr).Error
//	return
//}

// ModifyEdbDataLt 修改路透社数据
//func ModifyEdbDataLt(edbInfoId int64, dataTime string, value float64) (err error) {
//	o := global.DbMap[utils.DbNameIndex]
//	sql := ` UPDATE edb_data_lt SET value=?,modify_time=NOW() WHERE edb_info_id=? AND data_time=? `
//	err = o.Exec(sql, value, edbInfoId, dataTime).Error
//	return
//}

//func GetEdbDataLtMaxOrMinDate(edbCode string) (min_date, max_date string, err error) {
//	o := global.DbMap[utils.DbNameIndex]
//	sql := ` SELECT MIN(data_time) AS min_date,MAX(data_time) AS max_date FROM edb_data_lt WHERE edb_code=? `
//	err = o.Raw(sql, edbCode).Row().Scan(&min_date, &max_date)
//	return
//}

//func GetEdbDataLtByCodeAndDate(edbCode string, startDate string) (count int, err error) {
//	o := global.DbMap[utils.DbNameIndex]
//	sql := ` SELECT COUNT(1) AS count FROM edb_data_lt WHERE edb_code=? AND data_time=? `
//	err = o.Raw(sql, edbCode, startDate).Scan(&count).Error
//	return
//}

//func GetEdbDataLtByCode(edbCode string, size int) (items []*EdbInfoSearchData, err error) {
//	o := global.DbMap[utils.DbNameIndex]
//	sql := ` SELECT * FROM edb_data_lt WHERE edb_code=? ORDER BY data_time DESC LIMIT ? `
//	err = o.Raw(sql, edbCode, size).Find(&items).Error
//	return
//}

//type EdbDataFromLt struct {
//	Close map[int64]interface{} `json:"CLOSE"`
//}

// QueryEdbDataByLt 获取路透社数据
//func QueryEdbDataByLt(edbCode, startDate, endDate string) (dataList map[int64]interface{}, err error) {
//	dataList = make(map[int64]interface{})
//
//	ltUrl := utils.LtServerUrl + `edbInfo/ek?EdbCode=%s&StartDate=%s&EndDate=%s`
//	ltUrl = fmt.Sprintf(ltUrl, edbCode, startDate, endDate)
//	utils.FileLog.Info("ltUrl:%s", ltUrl)
//	body, err := http.Get(ltUrl)
//	utils.FileLog.Info("lt result:%s", string(body))
//
//	if err != nil {
//		return
//	}
//	//fmt.Println(string(body))
//	item := new(EdbDataFromLt)
//	err = json.Unmarshal(body, &item)
//
//	if err != nil {
//		return
//	}
//	dataList = item.Close
//	return
//}