|
@@ -183,13 +183,13 @@ func MultiInsertTradeBaseDataToTop(exchange string, startDate, endDate string) (
|
|
o := orm.NewOrmUsingDB("data")
|
|
o := orm.NewOrmUsingDB("data")
|
|
now := time.Now().Format(utils.FormatDateTime)
|
|
now := time.Now().Format(utils.FormatDateTime)
|
|
sql1 := `INSERT INTO trade_position_` + exchange + `_top(classify_name,classify_type,deal_short_name,deal_value,deal_change,data_time,deal_type,source_type,rank,create_time,modify_time)
|
|
sql1 := `INSERT INTO trade_position_` + exchange + `_top(classify_name,classify_type,deal_short_name,deal_value,deal_change,data_time,deal_type,source_type,rank,create_time,modify_time)
|
|
- SELECT classify_name,classify_type,buy_short_name,buy_value,buy_change,data_time,1,0,rank,?,? FROM base_from_trade_` + exchange + `_index where rank <50 and buy_short_name !="" and data_time between ? and ?`
|
|
|
|
|
|
+ SELECT classify_name,classify_type,buy_short_name,buy_value,buy_change,data_time,1,0,rank,?,? FROM base_from_trade_` + exchange + `_index where rank <50 and buy_short_name !='' and data_time between ? and ?`
|
|
_, err = o.Raw(sql1, now, now, startDate, endDate).Exec()
|
|
_, err = o.Raw(sql1, now, now, startDate, endDate).Exec()
|
|
if err != nil {
|
|
if err != nil {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
sql2 := `INSERT INTO trade_position_` + exchange + `_top(classify_name,classify_type,deal_short_name,deal_value,deal_change,data_time,deal_type,source_type,rank,create_time,modify_time)
|
|
sql2 := `INSERT INTO trade_position_` + exchange + `_top(classify_name,classify_type,deal_short_name,deal_value,deal_change,data_time,deal_type,source_type,rank,create_time,modify_time)
|
|
-SELECT classify_name,classify_type,sold_short_name,sold_value,sold_change,data_time,2,0,rank,?,? FROM base_from_trade_` + exchange + `_index where rank <50 and sold_short_name !="" and data_time between ? and ?`
|
|
|
|
|
|
+SELECT classify_name,classify_type,sold_short_name,sold_value,sold_change,data_time,2,0,rank,?,? FROM base_from_trade_` + exchange + `_index where rank <50 and sold_short_name !='' and data_time between ? and ?`
|
|
_, err = o.Raw(sql2, now, now, startDate, endDate).Exec()
|
|
_, err = o.Raw(sql2, now, now, startDate, endDate).Exec()
|
|
return
|
|
return
|
|
}
|
|
}
|