|
|
@@ -755,7 +755,7 @@ type Ermcp3ExposureHedgeplanDetail struct {
|
|
|
CONVERTRATIO float64 `json:"convertratio" xorm:"'CONVERTRATIO'"` // 折算系数(套保品种)
|
|
|
USERID int64 `json:"userid" xorm:"'USERID'"` // 机构id
|
|
|
HEDGEPLANID string `json:"hedgeplanid" xorm:"'HEDGEPLANID'"` // 套保计划id
|
|
|
- HEDGEPLANNO string `json:"hedgeplanno" xorm:"'HEDGEPLANNO'"` // 套保计划编号
|
|
|
+ HEDGEPLANNO string `json:"hedgeplanno" xorm:"'HEDGEPLANNO'"` // 套保计划名称
|
|
|
BIZTYPE int32 `json:"biztype" xorm:"'BIZTYPE'"` // 业务类型(期现用途,业务类型就是期现用途) 1-套保 2-套利
|
|
|
QTY float64 `json:"qty" xorm:"'QTY'"` // 合同量
|
|
|
PRICEDQTY float64 `json:"pricedqty" xorm:"'PRICEDQTY'"` // 已定价量
|
|
|
@@ -955,7 +955,7 @@ func (r *Ermcp3AreaSpotPLReport) buildSqlDay() string {
|
|
|
" sum(t.CURQTY) CURQTY," +
|
|
|
" sum(t.CURAVERAGEPRICE) CURAVERAGEPRICE," +
|
|
|
" sum(t.CURAMOUNT) CURAMOUNT," +
|
|
|
- " sum(t.CURSPOTPRICE) CURSPOTPRICE," +
|
|
|
+ " max(t.CURSPOTPRICE) CURSPOTPRICE," +
|
|
|
" sum(t.CURMARKETVALUE) CURMARKETVALUE," +
|
|
|
" sum(t.ACTUALPL) ACTUALPL," +
|
|
|
" sum(t.FLOATPL) FLOATPL," +
|
|
|
@@ -1015,7 +1015,7 @@ func (r *Ermcp3AreaSpotPLReport) buildSqlDayDetail() string {
|
|
|
" sum(t.CURQTY) CURQTY," +
|
|
|
" sum(t.CURAVERAGEPRICE) CURAVERAGEPRICE," +
|
|
|
" sum(t.CURAMOUNT) CURAMOUNT," +
|
|
|
- " sum(t.CURSPOTPRICE) CURSPOTPRICE," +
|
|
|
+ " max(t.CURSPOTPRICE) CURSPOTPRICE," +
|
|
|
" sum(t.CURMARKETVALUE) CURMARKETVALUE," +
|
|
|
" sum(t.ACTUALPL) ACTUALPL," +
|
|
|
" sum(t.FLOATPL) FLOATPL," +
|
|
|
@@ -1078,7 +1078,7 @@ func (r *Ermcp3AreaSpotPLReport) buildSqlCycle() string {
|
|
|
" sum(t.CURQTY) CURQTY," +
|
|
|
" sum(t.CURAVERAGEPRICE) CURAVERAGEPRICE," +
|
|
|
" sum(t.CURAMOUNT) CURAMOUNT," +
|
|
|
- " sum(t.CURSPOTPRICE) CURSPOTPRICE," +
|
|
|
+ " max(t.CURSPOTPRICE) CURSPOTPRICE," +
|
|
|
" sum(t.CURMARKETVALUE) CURMARKETVALUE," +
|
|
|
" sum(t.ACTUALPL) ACTUALPL," +
|
|
|
" sum(t.FLOATPL) FLOATPL," +
|
|
|
@@ -1898,12 +1898,12 @@ type Ermcp3TaFutuReDataReport struct {
|
|
|
CYCLETIME string `json:"cycletime" xorm:"CYCLETIME"` // 周期时间 月(YYYYMM) 季(YYYYQ) 年(YYYY) 周(YYYYIW) 全(0)【原值】
|
|
|
CYCLETYPE int32 `json:"cycletype" xorm:"CYCLETYPE"` // 周期类型 - 1:月 2:季 3:年 4:周 5:全报表【原值】
|
|
|
ACCOUNTID int64 `json:"accountid" xorm:"ACCOUNTID"` // 交易账户
|
|
|
- GOODSID string `json:"goodsid" xorm:"GOODSID"` // 交易合约
|
|
|
+ GOODSID int32 `json:"goodsid" xorm:"GOODSID"` // 交易合约
|
|
|
BUYORSELL int32 `json:"buyorsell" xorm:"BUYORSELL"` // 持仓方向
|
|
|
- CURRENCYID string `json:"currencyid" xorm:"CURRENCYID"` // 结算币种ID
|
|
|
+ CURRENCYID int32 `json:"currencyid" xorm:"CURRENCYID"` // 结算币种ID
|
|
|
USERID int64 `json:"userid" xorm:"USERID"` // 账户所属用户ID
|
|
|
- RELATEDUSERID string `json:"relateduserid" xorm:"RELATEDUSERID"` // 账户关联用户ID
|
|
|
- GOODSGROUPID string `json:"goodsgroupid" xorm:"GOODSGROUPID"` // 交易品种
|
|
|
+ RELATEDUSERID int64 `json:"relateduserid" xorm:"RELATEDUSERID"` // 账户关联用户ID
|
|
|
+ GOODSGROUPID int32 `json:"goodsgroupid" xorm:"GOODSGROUPID"` // 交易品种
|
|
|
ORIHOLDQTY float64 `json:"oriholdqty" xorm:"ORIHOLDQTY"` // 期初持仓量
|
|
|
ORIOPENAMOUNT float64 `json:"oriopenamount" xorm:"ORIOPENAMOUNT"` // 期初开仓额
|
|
|
ORIHOLDAMOUNT float64 `json:"oriholdamount" xorm:"ORIHOLDAMOUNT"` // 期初持仓额
|
|
|
@@ -1996,7 +1996,7 @@ func (r *Ermcp3TaFutuReDataReport) buildSqlReckon(userType int32) string {
|
|
|
" sum(t.CHARGE) CHARGE," +
|
|
|
" sum(t.CLOSEPL) CLOSEPL," +
|
|
|
" sum(t.RECKONPL) RECKONPL," +
|
|
|
- " sum(t.LASTPRICE) LASTPRICE," +
|
|
|
+ " max(t.LASTPRICE) LASTPRICE," +
|
|
|
" sum(t.LASTHOLDAMOUNT) LASTHOLDAMOUNT," +
|
|
|
" sum(t.FLOATPL) FLOATPL," +
|
|
|
" sum(t.GOODSGROUPSPOTQTY) GOODSGROUPSPOTQTY," +
|
|
|
@@ -2064,7 +2064,7 @@ func (r *Ermcp3TaFutuReDataReport) buildSqlReckonDetail(userType int32) string {
|
|
|
" sum(t.CHARGE) CHARGE," +
|
|
|
" sum(t.CLOSEPL) CLOSEPL," +
|
|
|
" sum(t.RECKONPL) RECKONPL," +
|
|
|
- " sum(t.LASTPRICE) LASTPRICE," +
|
|
|
+ " max(t.LASTPRICE) LASTPRICE," +
|
|
|
" sum(t.LASTHOLDAMOUNT) LASTHOLDAMOUNT," +
|
|
|
" sum(t.FLOATPL) FLOATPL," +
|
|
|
" sum(t.GOODSGROUPSPOTQTY) GOODSGROUPSPOTQTY," +
|
|
|
@@ -2095,6 +2095,11 @@ func (r *Ermcp3TaFutuReDataReport) buildSqlReckonDetail(userType int32) string {
|
|
|
sqlParam.AndEx("t.relateduserid", r.USERID, userType == 7)
|
|
|
userId = "RELATEDUSERID"
|
|
|
}
|
|
|
+ sqlParam.And("t.CURRENCYID", r.CURRENCYID)
|
|
|
+ sqlParam.And("t.GOODSGROUPID", r.GOODSGROUPID)
|
|
|
+ sqlParam.And("t.GOODSID", r.GOODSID)
|
|
|
+ sqlParam.And("t.BUYORSELL", r.BUYORSELL)
|
|
|
+
|
|
|
sqlParam.AndEx("t.reckondate", r.RECKONDATE, len(r.RECKONDATE) > 0)
|
|
|
if len(r.BeginDate) > 0 && len(r.EndDate) > 0 {
|
|
|
sqlParam.Join(fmt.Sprintf(" and t.RECKONDATE >= '%v' and t.RECKONDATE <= '%v' ", r.BeginDate, r.EndDate))
|
|
|
@@ -2133,7 +2138,7 @@ func (r *Ermcp3TaFutuReDataReport) buildSqlReport(userType int32) string {
|
|
|
" sum(t.CHARGE) CHARGE," +
|
|
|
" sum(t.CLOSEPL) CLOSEPL," +
|
|
|
" sum(t.RECKONPL) RECKONPL," +
|
|
|
- " sum(t.LASTPRICE) LASTPRICE," +
|
|
|
+ " max(t.LASTPRICE) LASTPRICE," +
|
|
|
" sum(t.LASTHOLDAMOUNT) LASTHOLDAMOUNT," +
|
|
|
" sum(t.FLOATPL) FLOATPL," +
|
|
|
" sum(t.GOODSGROUPSPOTQTY) GOODSGROUPSPOTQTY," +
|
|
|
@@ -2143,9 +2148,6 @@ func (r *Ermcp3TaFutuReDataReport) buildSqlReport(userType int32) string {
|
|
|
" sum(t.Reckonpl2) RECKONPL2" +
|
|
|
" FROM REPORT_ERMCP_TAFUTUREDATA t" +
|
|
|
" WHERE 1 = 1 %v" +
|
|
|
- " and t.userid = 8888" +
|
|
|
- " and t.cycletype = 1" +
|
|
|
- " and t.cycletime = '202105'" +
|
|
|
" GROUP BY t.cycletype," +
|
|
|
" t.cycletime," +
|
|
|
" t.GOODSID," +
|