Ver código fonte

Merge branch 'master' of http://192.168.31.240:3000/MTP2.0_New/MTP20_IF

muchinfo 3 semanas atrás
pai
commit
148a51a1dd
8 arquivos alterados com 778 adições e 384 exclusões
  1. 2 1
      controllers/tradexx/qryTradexx.go
  2. 254 116
      docs/docs.go
  3. 254 115
      docs/swagger.json
  4. 204 121
      docs/swagger.yaml
  5. 18 9
      models/ermcpGoods.go
  6. 7 7
      models/taaccountdigital.go
  7. 25 6
      models/tradexx.go
  8. 14 9
      models/wrTrade2.go

+ 2 - 1
controllers/tradexx/qryTradexx.go

@@ -17,11 +17,12 @@ import (
 // @Summary  查询持仓明细
 // @Produce  json
 // @Security ApiKeyAuth
-// @Param    userid          query    int    false "用户id"
+// @Param    userid          query    int    true "用户id"
 // @Param    accids          query    string false "资金账号, 格式 1,2,3"
 // @Param    trademodes      query    string false "交易模式, 格式 1,2,3"
 // @Param    marketids       query    string false "市场id, 格式 1,2,3"
 // @Param    goodsid         query    int    false "商品id"
+// @Param    tradeid		 query    string false "成交单号"
 // @Param    buyorsell       query    int    false "买卖方向 0-买 1-卖"
 // @Param    riskcontrolmode query    int    false "风控方式(52模式) 1:按单风控 2:按账户风控"
 // @Success  200             {array}  models.TradeHolderDetail

Diferenças do arquivo suprimidas por serem muito extensas
+ 254 - 116
docs/docs.go


Diferenças do arquivo suprimidas por serem muito extensas
+ 254 - 115
docs/swagger.json


Diferenças do arquivo suprimidas por serem muito extensas
+ 204 - 121
docs/swagger.yaml


+ 18 - 9
models/ermcpGoods.go

@@ -114,18 +114,23 @@ type ErmcpGoods struct {
 	RISKCONTROLMODE      int32  `json:"riskcontrolmode" xorm:"RISKCONTROLMODE"`           // 风控方式(52、10模式) 1:按单风控 2:按账户风控
 	GOODSNAMEVI          string `json:"goodsnamevi" xorm:"GOODSNAMEVI"`                   // 期货合约名称(越南语)
 
-	TPSLFLAG       int32   `json:"tpslflag"  xorm:"TPSLFLAG"`            // 是否开启止盈止损 - 0:不开启 1:开启
-	TPSLFORCEFLAG  int32   `json:"tpslforceflag"  xorm:"TPSLFORCEFLAG"`  // 是否强制止盈止损 - 0:不强制 1:强制
-	TPRATIODOWN    float64 `json:"tpratiodown" xorm:"TPRATIODOWN"`       // 止盈比例下限
-	TPRATIOUP      float64 `json:"tpratioup" xorm:"TPRATIOUP"`           // 止盈比例上限
-	TPRATIODEFAULT float64 `json:"tpratiodefault" xorm:"TPRATIODEFAULT"` // 止盈默认比例
-	SLRATIODOWN    float64 `json:"slratiodown" xorm:"SLRATIODOWN"`       // 止损比例下限
-	SLRATIOUP      float64 `json:"slratioup" xorm:"SLRATIOUP"`           // 止损比例上限
-	SLRATIODEFAULT float64 `json:"slratiodefault" xorm:"SLRATIODEFAULT"` // 止损默认比例
+	TPSLFLAG       int32   `json:"tpslflag"  xorm:"TPSLFLAG"`            // 是否开启止盈止损 - 0:不开启 1:开启(按单风控、按账户风控)
+	TPSLFORCEFLAG  int32   `json:"tpslforceflag"  xorm:"TPSLFORCEFLAG"`  // 是否强制止盈止损 - 0:不强制 1:强制(按单风控)
+	TPRATIODOWN    float64 `json:"tpratiodown" xorm:"TPRATIODOWN"`       // 止盈比例下限(按单风控)
+	TPRATIOUP      float64 `json:"tpratioup" xorm:"TPRATIOUP"`           // 止盈比例上限(按单风控)
+	TPRATIODEFAULT float64 `json:"tpratiodefault" xorm:"TPRATIODEFAULT"` // 止盈默认比例(按单风控)
+	SLRATIODOWN    float64 `json:"slratiodown" xorm:"SLRATIODOWN"`       // 止损比例下限(按单风控)
+	SLRATIOUP      float64 `json:"slratioup" xorm:"SLRATIOUP"`           // 止损比例上限(按单风控)
+	SLRATIODEFAULT float64 `json:"slratiodefault" xorm:"SLRATIODEFAULT"` // 止损默认比例(按单风控)
 
 	BASECURRENCYCODE  string `json:"basecurrencycode" xorm:"BASECURRENCYCODE"`   // 基础货币代码(80:Goodscurrencyid)
 	QUOTECURRENCYCODE string `json:"quotecurrencycode" xorm:"QUOTECURRENCYCODE"` // 计价货币代码(80:currencyid)
 
+	BUYTPPOINT  int32 `json:"buytppoint"  xorm:"BUYTPPOINT"`   // 买止盈点差(按账户风控)
+	BUYSLPOINT  int32 `json:"buyslpoint"  xorm:"BUYSLPOINT"`   // 买止损点差(按账户风控)
+	SELLTPPOINT int32 `json:"selltppoint"  xorm:"SELLTPPOINT"` // 卖止盈点差(按账户风控)
+	SELLSLPOINT int32 `json:"sellslpoint"  xorm:"SELLSLPOINT"` // 卖止损点差(按账户风控)
+
 }
 
 // GetErmcpGoodses 企业风管专用获取商品信息的方法
@@ -195,7 +200,11 @@ func GetErmcpGoodses(userid int64, lastUpdateTime string, loginID int64) ([]Ermc
 			EX.SLRATIOUP,
 			EX.SLRATIODEFAULT,
 			EN1.ENUMDICNAME BASECURRENCYCODE,
-			EN2.ENUMDICNAME QUOTECURRENCYCODE     
+			EN2.ENUMDICNAME QUOTECURRENCYCODE,
+			EX.BUYTPPOINT,
+			EX.BuySLPOINT,
+			EX.SELLTPPOINT,
+			EX.SELLSLPOINT
 			`).
 		Join("LEFT", "MARKET M", "M.MARKETID = G.MARKETID").
 		Join("LEFT", "GOODSMARGINCONFIG GM", "GM.GOODSID = G.GOODSID AND GM.ISDEFAULT = 1").

+ 7 - 7
models/taaccountdigital.go

@@ -37,7 +37,7 @@ type Taaccountdigital struct {
 
 	TIMESTAMP uint64 `json:"timestamp" xorm:"-"` // 当前时间戳(毫秒)
 
-	CURRENCYIDS string `json:"-" xorm:"-" form:"currencyids"` // 币种ID(多个逗号分隔)
+	CURRENCYIDS string `json:"currencyids" xorm:"-" form:"currencyids"` // 币种ID(多个逗号分隔)
 }
 
 func (r *Taaccountdigital) calc() {
@@ -120,8 +120,8 @@ type Taaccountdigitalchangeapply struct {
 	REMARK              string    `json:"remark" xorm:"REMARK"`                                                                // 备注
 	RETCODE             string    `json:"retcode" xorm:"RETCODE"`                                                              // 错误代码
 
-	APPLYDATE     string `json:"-" xorm:"-" form:"applydate"`     // 申请日期(yyyyMMdd)
-	TRANSFERTYPES string `json:"-" xorm:"-" form:"transfertypes"` // 划转类型(多个逗号分隔) - 枚举"digitaltransfertype"(1:充值 2:提现 3:转入 4:转出)
+	APPLYDATE     string `json:"applydate" xorm:"-" form:"applydate"`         // 申请日期(yyyyMMdd)
+	TRANSFERTYPES string `json:"transfertypes" xorm:"-" form:"transfertypes"` // 划转类型(多个逗号分隔) - 枚举"digitaltransfertype"(1:充值 2:提现 3:转入 4:转出)
 
 	PageEx `xorm:"extends"` // 页码信息
 }
@@ -175,7 +175,7 @@ type Taaccountdigitallog struct {
 	TRADEDATE           string    `json:"tradedate" xorm:"TRADEDATE" form:"tradedate"`                                         // 创建交易日(yyyyMMdd)
 	REMARK              string    `json:"remark" xorm:"REMARK"`                                                                // 备注
 
-	BUSINESSCODES string `json:"-" xorm:"-" form:"businesscodes"` // 业务类型(多个逗号分隔) - 枚举digitalbusinesscode(1:充值 2:提现 3:转入 4:转出 5:现货交易 6:现货交易手续费 7:提现手续费...)
+	BUSINESSCODES string `json:"businesscodes" xorm:"-" form:"businesscodes"` // 业务类型(多个逗号分隔) - 枚举digitalbusinesscode(1:充值 2:提现 3:转入 4:转出 5:现货交易 6:现货交易手续费 7:提现手续费...)
 
 	PageEx `xorm:"extends"` // 页码信息
 }
@@ -256,8 +256,8 @@ type DigitaltradeOrderdetail struct {
 	RETCODE         uint64    `json:"retcode" xorm:"RETCODE"`                                // 错误代码
 	TRADEPROPERTY   uint32    `json:"tradeproperty" xorm:"TRADEPROPERTY"`                    // 交易属性
 
-	ORDERSTATUSES    string `json:"-" xorm:"-" form:"orderstatuses"`    // 委托状态(多个逗号分隔) 参考枚举orderstatus
-	DIGITALACCOUNTID string `json:"-" xorm:"-" form:"digitalaccountid"` // 数字账户ID
+	ORDERSTATUSES    string `json:"orderstatuses" xorm:"-" form:"orderstatuses"`       // 委托状态(多个逗号分隔) 参考枚举orderstatus
+	DIGITALACCOUNTID string `json:"digitalaccountid" xorm:"-" form:"digitalaccountid"` // 数字账户ID
 
 	PageEx `xorm:"extends"` // 页码信息
 }
@@ -329,7 +329,7 @@ type DigitaltradeTradedetail struct {
 	OPENMEMBERCHARGEVALUE  float64   `json:"openmemberchargevalue" xorm:"OPENMEMBERCHARGEVALUE"`    // 手续费设置值(会员部分)
 	TRADEPROPERTY          uint32    `json:"tradeproperty" xorm:"TRADEPROPERTY"`                    // 交易属性
 
-	DIGITALACCOUNTID string `json:"-" xorm:"-" form:"digitalaccountid"` // 数字账户ID
+	DIGITALACCOUNTID string `json:"digitalaccountid" xorm:"-" form:"digitalaccountid"` // 数字账户ID
 
 	PageEx `xorm:"extends"` // 页码信息
 }

+ 25 - 6
models/tradexx.go

@@ -33,10 +33,10 @@ type TradeGoodsEx struct {
 
 // TradeAccountEx 交易账户相关字段
 type TradeAccountEx struct {
-	TANAME       string `json:"taname"  xorm:"'TANAME'"`               // 资金账号名称
-	USERID       int64  `json:"userid"  xorm:"'USERID'" form:"userid"` // 用户id
-	USERNAME     string `json:"username"  xorm:"'USERNAME'"`           // 用户名称
-	TaCurrencyid int64  `json:"tacurrencyid"  xorm:"'TACURRENCYID'"`   // 报价货币ID - taaccount
+	TANAME       string `json:"taname"  xorm:"'TANAME'"`                                  // 资金账号名称
+	USERID       int64  `json:"userid"  xorm:"'USERID'" form:"userid" binding:"required"` // 用户id
+	USERNAME     string `json:"username"  xorm:"'USERNAME'"`                              // 用户名称
+	TaCurrencyid int64  `json:"tacurrencyid"  xorm:"'TACURRENCYID'"`                      // 报价货币ID - taaccount
 }
 
 // TradePosition 持仓汇总
@@ -217,6 +217,15 @@ type TradeHolderDetail struct {
 	FtTradeMode     string `json:"-" form:"trademodes"`                                           // 交易模式筛选, 逗号隔开
 	FtMarketIDs     string `json:"-" form:"marketids"`                                            // 市场id, 逗号隔开
 	RISKCONTROLMODE int32  `json:"riskcontrolmode" form:"riskcontrolmode" xorm:"RISKCONTROLMODE"` // 风控方式(52模式) 1:按单风控 2:按账户风控
+
+	TPSL_TPFLAG         int32  `json:"tpsl_tpflag" xorm:"TPFLAG"`                 // 止盈标识 - 0:未设置 1:已设置(10按账户风控)
+	TPSL_TPPRICE        string `json:"tpsl_tpprice" xorm:"TPPRICE"`               // 止盈价格(10按账户风控)
+	TPSL_SLFLAG         int32  `json:"tpsl_slflag" xorm:"SLFLAG"`                 // 止损标识 - 0:未设置 1:已设置(10按账户风控)
+	TPSL_SLPRICE        string `json:"tpsl_slprice" xorm:"SLPRICE"`               // 止损价格(10按账户风控)
+	TPSL_ORDERSTATUS    int32  `json:"tpsl_orderstatus" xorm:"TPSL_ORDERSTATUS"`  // 止盈止损单状态 - 1:待执行 2:执行中 3:已执行 4:已失效 5:执行失败(10按账户风控)
+	TPSL_EXECUTETIME    string `json:"tpsl_executetime" xorm:"EXECUTETIME"`       // 执行时间(10按账户风控)
+	TPSL_EXECUTEPRICE   string `json:"tpsl_executeprice" xorm:"EXECUTEPRICE"`     // 执行价格(10按账户风控)
+	TPSL_EXECUTERETCODE int32  `json:"tpsl_executeretcode" xorm:"EXECUTERETCODE"` // 执行错误代码(10按账户风控)
 }
 
 func (r *TradeHolderDetail) calc() {
@@ -293,17 +302,27 @@ SELECT to_char(t.TRADEID) TRADEID,
        t.HOLDERCREDIT,
        t.RELEASEHOLDERCREDIT,
        gtmp.*,
-       utmp.*
+       utmp.*,
+	   tpsl.TPFLAG,
+	   tpsl.TPPRICE,
+	   tpsl.SLFLAG,
+	   tpsl.SLPRICE,
+	   tpsl.ORDERSTATUS TPSL_ORDERSTATUS,
+	   TO_CHAR(tpsl.EXECUTETIME, 'YYYY-MM-DD HH24:MI:SS') EXECUTETIME,
+	   tpsl.EXECUTEPRICE, 
+	   tpsl.EXECUTERETCODE
   FROM TRADE_HOLDERDETAIL t
   INNER JOIN gtmp on t.goodsid=gtmp.goodsid
   LEFT JOIN utmp on t.accountid=utmp.accountid
- WHERE 1 = 1 and t.HOLDERQTY > 0
+  LEFT JOIN trade_holdertpslorder tpsl on t.tradeid = tpsl.tradeid and t.buyorsell = tpsl.buyorsell
+  WHERE 1 = 1 and t.HOLDERQTY > 0
 `
 
 	sqlId.AndEx("gtmp.riskcontrolmode", r.RISKCONTROLMODE, r.RISKCONTROLMODE > 0)
 	sqlId.AndEx("utmp.userid", r.USERID, r.USERID > 0)
 	sqlId.AndEx("t.goodsid", r.GOODSID, r.GOODSID > 0)
 	sqlId.AndEx("t.BUYORSELL", r.BUYORSELL, r.BUYORSELL != -1)
+	sqlId.AndEx("t.tradeid", r.TRADEID, r.TRADEID != "")
 	sqlId.JoinEx(r.FtTradeMode != "", fmt.Sprintf(" and gtmp.trademode in(%v)", r.FtTradeMode))
 	sqlId.JoinEx(r.FtMarketIDs != "", fmt.Sprintf(" and gtmp.marketid in(%v)", r.FtMarketIDs))
 	sqlId.JoinEx(r.FtAccountIDs != "", fmt.Sprintf(" and t.accountid in(%v)", r.FtAccountIDs))

+ 14 - 9
models/wrTrade2.go

@@ -5054,6 +5054,8 @@ type WrDraftUserInfo struct {
 	CREDITQUOTA              float64 `json:"creditquota"  xorm:"CREDITQUOTA"`                           // 授信额度(金瑞)
 
 	Bankbankname string `json:"bankbankname"  xorm:"BANKBANKNAME"` // 银行名称
+	MODIFYSTATUS int32  `json:"modifystatus"  xorm:"MODIFYSTATUS"` // 变更状态(枚举'modifystatus')
+	HASAUTH      int32  `json:"hasauth"  xorm:"HASAUTH"`           // 是否已实名(枚举'hasauth')
 }
 
 func (r *WrDraftUserInfo) calc() {
@@ -5069,15 +5071,18 @@ func (r *WrDraftUserInfo) calc() {
 
 func (r *WrDraftUserInfo) buildSql() string {
 	var sqlId utils.SQLVal = `
-SELECT to_char(t.BIRTHDAY, 'yyyy-mm-dd hh24:mi:ss') BIRTHDAY2,
-       to_char(t.CREATETIME, 'yyyy-mm-dd hh24:mi:ss') CREATETIME2,
-       to_char(t.MODIFIERTIME, 'yyyy-mm-dd hh24:mi:ss') MODIFIERTIME2,
-       t.*,
-	   b.bankname BANKBANKNAME
-  FROM DRAFT_USERINFO t
-  LEFT JOIN bank_bankinfo b on b.bankid = t.bankid
- WHERE 1 = 1
-`
+		SELECT to_char(t.BIRTHDAY, 'yyyy-mm-dd hh24:mi:ss') BIRTHDAY2,
+		to_char(t.CREATETIME, 'yyyy-mm-dd hh24:mi:ss') CREATETIME2,
+		to_char(t.MODIFIERTIME, 'yyyy-mm-dd hh24:mi:ss') MODIFIERTIME2,
+		t.*,
+		b.bankname BANKBANKNAME,
+		ua.modifystatus MODIFYSTATUS,
+		ua.hasauth HASAUTH
+		FROM DRAFT_USERINFO t
+		LEFT JOIN bank_bankinfo b on b.bankid = t.bankid
+		LEFT JOIN useraccount ua on ua.userid = t.userid
+		WHERE 1 = 1
+	`
 	sqlId.And("t.userid", r.USERID)
 	sqlId.AndEx("t.userstatus", r.USERSTATUS, r.USERSTATUS != 0)
 	return sqlId.String()

Alguns arquivos não foram mostrados porque muitos arquivos mudaram nesse diff