|
@@ -240,3 +240,31 @@ func BatchAddBaseFromSciHqData(list []*BaseFromSciHqData) (err error) {
|
|
|
_, err = o.InsertMulti(500, list)
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
+func GetSciHqIndexInfoMaxAndMinInfo(indexCode string) (item *EdbInfoMaxAndMinInfo, err error) {
|
|
|
+ o := orm.NewOrm()
|
|
|
+ sql := ` SELECT MIN(data_time) AS min_date,MAX(data_time) AS max_date,MIN(value) AS min_value,MAX(value) AS max_value FROM base_from_sci_hq_data WHERE index_code=? `
|
|
|
+ err = o.Raw(sql, indexCode).QueryRow(&item)
|
|
|
+
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 获取最新值
|
|
|
+ var latest_value float64
|
|
|
+ sql = ` SELECT value AS latest_value FROM base_from_sci_hq_data WHERE index_code=? ORDER BY data_time DESC LIMIT 1 `
|
|
|
+ err = o.Raw(sql, indexCode).QueryRow(&latest_value)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ item.LatestValue = latest_value
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func ModifySciHqIndexMaxAndMinInfo(indexCode string, item *EdbInfoMaxAndMinInfo) (err error) {
|
|
|
+ o := orm.NewOrm()
|
|
|
+ sql := ` UPDATE base_from_sci_hq_index SET start_date=?,end_date=?,modify_time=NOW() WHERE index_code=? `
|
|
|
+ _, err = o.Raw(sql, item.MinDate, item.MaxDate, indexCode).Exec()
|
|
|
+ return
|
|
|
+}
|