|
|
@@ -4665,6 +4665,7 @@ type WrReckonSpotGoodsTradeSum struct {
|
|
|
ENDDATE string `json:"enddate" form:"enddate"` // 结束日期(结果含结束日期) yyyymmdd
|
|
|
LastNum int `json:"-" form:"lastnum"` // 最近多少条记录
|
|
|
|
|
|
+ ISTODAY bool `json:"istoday" form:"istoday"` // 是否当日
|
|
|
}
|
|
|
|
|
|
func (r *WrReckonSpotGoodsTradeSum) calc() {
|
|
|
@@ -4717,7 +4718,7 @@ func (r *WrReckonSpotGoodsTradeSum) buildSqlByToday(today string) string {
|
|
|
from WRTrade_TradeDetail t
|
|
|
left join WRFactorType w on w.WRFactorTypeID = t.WRFactorTypeID
|
|
|
where t.marketid = %v and w.wrstandardid = %v
|
|
|
- order by t.TradeTime desc)
|
|
|
+ order by t.WRTradeDetailID desc)
|
|
|
select distinct
|
|
|
t.RECKONDATE,
|
|
|
t.marketid,
|
|
|
@@ -4735,11 +4736,11 @@ func (r *WrReckonSpotGoodsTradeSum) buildSqlByToday(today string) string {
|
|
|
func (r *WrReckonSpotGoodsTradeSum) GetDataEx() (interface{}, error) {
|
|
|
sql := r.buildSql()
|
|
|
// 判断是否获取今日走势
|
|
|
- if r.MARKETID > 0 && r.ENDDATE != "" {
|
|
|
+ if r.MARKETID > 0 && r.ISTODAY {
|
|
|
if marketRun, err := GetMarketRun(r.MARKETID); err == nil {
|
|
|
- if marketRun.Tradedate == r.ENDDATE {
|
|
|
- sql = r.buildSqlByToday(marketRun.Tradedate)
|
|
|
- }
|
|
|
+ sql = r.buildSqlByToday(marketRun.Tradedate)
|
|
|
+ } else {
|
|
|
+ return nil, errors.New("数据异常")
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -4749,6 +4750,7 @@ func (r *WrReckonSpotGoodsTradeSum) GetDataEx() (interface{}, error) {
|
|
|
sData[i].calc()
|
|
|
sData[i].BEGINDATE = r.BEGINDATE
|
|
|
sData[i].ENDDATE = r.ENDDATE
|
|
|
+ sData[i].ISTODAY = r.ISTODAY
|
|
|
}
|
|
|
return sData, err
|
|
|
}
|