|
|
@@ -5123,3 +5123,71 @@ func (r *XhcpSellBackApplyEx) Insert() error {
|
|
|
// add Commit() after all actions
|
|
|
return session.Commit()
|
|
|
}
|
|
|
+
|
|
|
+// Wrtradetradequote 仓单贸易成交行情表
|
|
|
+type Wrtradetradequote struct {
|
|
|
+ WRTRADEDETAILID string `json:"wrtradedetailid" xorm:"WRTRADEDETAILID"` // 仓单贸易成交单ID(321+Unix秒时间戳(10位)+xxxxxx)
|
|
|
+ TRADEDATE string `json:"tradedate" xorm:"TRADEDATE"` // 交易日(yyyyMMdd)
|
|
|
+ MARKETID int32 `json:"marketid" xorm:"MARKETID" form:"marketid"` // 市场ID
|
|
|
+ WRFACTORTYPEID int64 `json:"wrfactortypeid" xorm:"WRFACTORTYPEID"` // 仓单要素类型ID
|
|
|
+ DELIVERYGOODSID int32 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID
|
|
|
+ WRSTANDARDID int32 `json:"wrstandardid" xorm:"WRSTANDARDID" form:"wrstandardid"` // 现货商品ID
|
|
|
+ BUYUSERID int64 `json:"buyuserid" xorm:"BUYUSERID"` // 买方用户ID
|
|
|
+ BUYACCOUNTID int64 `json:"buyaccountid" xorm:"BUYACCOUNTID"` // 买方账号ID
|
|
|
+ SELLUSERID int64 `json:"selluserid" xorm:"SELLUSERID"` // 卖方用户ID
|
|
|
+ SELLACCOUNTID int64 `json:"sellaccountid" xorm:"SELLACCOUNTID"` // 卖方账号ID
|
|
|
+ TRADETIME time.Time `json:"tradetime" xorm:"TRADETIME"` // 成交时间
|
|
|
+ TRADEPRICE float64 `json:"tradeprice" xorm:"TRADEPRICE"` // 成交价格
|
|
|
+ TRADEQTY int64 `json:"tradeqty" xorm:"TRADEQTY"` // 成交数量
|
|
|
+ TRADEAMOUNT float64 `json:"tradeamount" xorm:"TRADEAMOUNT"` // 成交金额
|
|
|
+
|
|
|
+ BEGINDATE string `json:"begindate" form:"begindate"` // 开始日期(结果含开始日期) yyyymmdd
|
|
|
+ ENDDATE string `json:"enddate" form:"enddate"` // 结束日期(结果含结束日期) yyyymmdd
|
|
|
+}
|
|
|
+
|
|
|
+// TableName is WRTRADE_TRADEQUOTE
|
|
|
+func (r *Wrtradetradequote) TableName() string {
|
|
|
+ return "WRTRADE_TRADEQUOTE"
|
|
|
+}
|
|
|
+
|
|
|
+func (r *Wrtradetradequote) calc() {
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+func (r *Wrtradetradequote) buildSql() string {
|
|
|
+ var sqlId utils.SQLVal = `
|
|
|
+ SELECT
|
|
|
+ to_char(t.WRTRADEDETAILID) WRTRADEDETAILID,
|
|
|
+ t.TRADEDATE,
|
|
|
+ t.MARKETID,
|
|
|
+ t.WRFACTORTYPEID,
|
|
|
+ t.DELIVERYGOODSID,
|
|
|
+ t.WRSTANDARDID,
|
|
|
+ t.BUYUSERID,
|
|
|
+ t.BUYACCOUNTID,
|
|
|
+ t.SELLUSERID,
|
|
|
+ t.SELLACCOUNTID,
|
|
|
+ t.TRADETIME,
|
|
|
+ t.TRADEPRICE,
|
|
|
+ t.TRADEQTY,
|
|
|
+ t.TRADEAMOUNT
|
|
|
+ FROM WRTRADE_TRADEQUOTE t
|
|
|
+ WHERE
|
|
|
+ t.WRSTANDARDID = %v
|
|
|
+ AND
|
|
|
+ t.TRADETIME BETWEEN TO_DATE('%v' || ' 000000', 'yyyymmdd hh24:mi:ss') and TO_DATE('%v' || ' 235959', 'yyyymmdd hh24:mi:ss')
|
|
|
+ `
|
|
|
+ sqlId.FormatParam(r.WRSTANDARDID, r.BEGINDATE, r.ENDDATE)
|
|
|
+ sqlId.AndEx("t.MARKETID", r.MARKETID, r.MARKETID > 0)
|
|
|
+
|
|
|
+ return sqlId.String()
|
|
|
+}
|
|
|
+
|
|
|
+func (r *Wrtradetradequote) GetDataEx() (interface{}, error) {
|
|
|
+ sData := make([]Wrtradetradequote, 0)
|
|
|
+ err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
|
|
|
+ for i := range sData {
|
|
|
+ sData[i].calc()
|
|
|
+ }
|
|
|
+ return sData, err
|
|
|
+}
|