|
@@ -168,14 +168,14 @@ func MultiUpdatePositionTop(exchange string, updates []UpdateDealValueChange) (e
|
|
|
|
|
|
func DeletePositionTopByDataTime(exchange string, dataTime string, dealType int) (err error) {
|
|
|
o := orm.NewOrm()
|
|
|
- sql := "delete from trade_position_" + exchange + "_Top WHERE data_time=? and deal_type=?"
|
|
|
+ sql := "delete from trade_position_" + exchange + "_top WHERE data_time=? and deal_type=?"
|
|
|
_, err = o.Raw(sql, dataTime, dealType).Exec()
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetTradePositionTopByExchangeDataTimeType(exchange string, dataTime string, dealType int) (list []TradePositionTop, err error) {
|
|
|
o := orm.NewOrm()
|
|
|
- sql := "select * from trade_position_" + exchange + "_Top WHERE data_time=? and deal_type=?"
|
|
|
+ sql := "select * from trade_position_" + exchange + "_top WHERE data_time=? and deal_type=?"
|
|
|
_, err = o.Raw(sql, dataTime, dealType).QueryRows(&list)
|
|
|
return
|
|
|
}
|