ermcpOrder.go 93 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166
  1. package models
  2. import (
  3. "fmt"
  4. "mtp2_if/db"
  5. "time"
  6. )
  7. // 企业风管期货单据相关
  8. // Hedgeouttradeposition 对冲外部持仓头寸表 - 导历史
  9. type Hedgeouttradeposition struct {
  10. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'" binding:"required"` // 资金账号[外部母账户]
  11. Hedgegoodsid int64 `json:"hedgegoodsid" xorm:"'HEDGEGOODSID'" binding:"required"` // 对冲合约ID
  12. Hedgeaccountcode string `json:"hedgeaccountcode" xorm:"'HEDGEACCOUNTCODE'"` // 对冲账号
  13. Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd)
  14. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  15. Ydbuyposition int64 `json:"ydbuyposition" xorm:"'YDBUYPOSITION'"` // 期初买头寸
  16. Curbuyposition int64 `json:"curbuyposition" xorm:"'CURBUYPOSITION'"` // 期末买头寸
  17. Curydbuyposition int64 `json:"curydbuyposition" xorm:"'CURYDBUYPOSITION'"` // 期末上日买头寸
  18. Curtdbuyposition int64 `json:"curtdbuyposition" xorm:"'CURTDBUYPOSITION'"` // 期末今日买头寸
  19. Freydbuyposition int64 `json:"freydbuyposition" xorm:"'FREYDBUYPOSITION'"` // 冻结上日买头寸
  20. Fretdbuyposition int64 `json:"fretdbuyposition" xorm:"'FRETDBUYPOSITION'"` // 冻结今日买头寸
  21. Ydsellposition int64 `json:"ydsellposition" xorm:"'YDSELLPOSITION'"` // 期初卖头寸
  22. Cursellposition int64 `json:"cursellposition" xorm:"'CURSELLPOSITION'"` // 期末卖头寸
  23. Curydsellposition int64 `json:"curydsellposition" xorm:"'CURYDSELLPOSITION'"` // 期末上日卖头寸
  24. Curtdsellposition int64 `json:"curtdsellposition" xorm:"'CURTDSELLPOSITION'"` // 期末今日卖头寸
  25. Freydsellposition int64 `json:"freydsellposition" xorm:"'FREYDSELLPOSITION'"` // 冻结上日卖头寸
  26. Fretdsellposition int64 `json:"fretdsellposition" xorm:"'FRETDSELLPOSITION'"` // 冻结今日卖头寸
  27. Buyopencost float64 `json:"buyopencost" xorm:"'BUYOPENCOST'"` // 买开仓成本
  28. Buypositioncost float64 `json:"buypositioncost" xorm:"'BUYPOSITIONCOST'"` // 买持仓成本
  29. Buyusemargin float64 `json:"buyusemargin" xorm:"'BUYUSEMARGIN'"` // 买占用保证金
  30. Sellopencost float64 `json:"sellopencost" xorm:"'SELLOPENCOST'"` // 卖开仓成本
  31. Sellpositioncost float64 `json:"sellpositioncost" xorm:"'SELLPOSITIONCOST'"` // 卖持仓成本
  32. Sellusemargin float64 `json:"sellusemargin" xorm:"'SELLUSEMARGIN'"` // 卖占用保证金
  33. }
  34. // TableName is HEDGE_OUTTRADEPOSITION
  35. func (Hedgeouttradeposition) TableName() string {
  36. return "HEDGE_OUTTRADEPOSITION"
  37. }
  38. // Hedgeoutorderdetail 对冲外部委托单表 - 导历史
  39. type Hedgeoutorderdetail struct {
  40. Outorderid int64 `json:"outorderid" xorm:"'OUTORDERID'" binding:"required"` // 外部委托单ID(113+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
  41. Hedgeaccountcode string `json:"hedgeaccountcode" xorm:"'HEDGEACCOUNTCODE'" binding:"required"` // 对冲账号
  42. Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd)
  43. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 资金账号[外部母账户]
  44. Relatedorderid int64 `json:"relatedorderid" xorm:"'RELATEDORDERID'"` // 关联内部委托单号
  45. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  46. Hedgegoodsid int64 `json:"hedgegoodsid" xorm:"'HEDGEGOODSID'"` // 对冲合约ID
  47. Orderpricetype int32 `json:"orderpricetype" xorm:"'ORDERPRICETYPE'"` // 报单价格条件 - 1:市价 2: 限价
  48. Buyorsell int32 `json:"buyorsell" xorm:"'BUYORSELL'"` // 买卖方向 - 0:买 1:卖
  49. Channelbuildtype int32 `json:"channelbuildtype" xorm:"'CHANNELBUILDTYPE'"` // 开平标志- 0:无 1:建仓 2:平仓
  50. Closetype int32 `json:"closetype" xorm:"'CLOSETYPE'"` // 平仓方式 - 0:无 1:平今 2:平昨
  51. Orderprice float64 `json:"orderprice" xorm:"'ORDERPRICE'"` // 委托价格
  52. Orderqty int64 `json:"orderqty" xorm:"'ORDERQTY'"` // 委托数量
  53. Tradeqty int64 `json:"tradeqty" xorm:"'TRADEQTY'"` // 成交数量
  54. Cancelqty int64 `json:"cancelqty" xorm:"'CANCELQTY'"` // 撤销数量
  55. Validtype int32 `json:"validtype" xorm:"'VALIDTYPE'"` // 有效期类型 - 1::当日有效
  56. Hedgeflag int32 `json:"hedgeflag" xorm:"'HEDGEFLAG'"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利
  57. Channeloutorderstatus int32 `json:"channeloutorderstatus" xorm:"'CHANNELOUTORDERSTATUS'"` // 外部单据状态 - 1 - 接收报文 2 - 发送报文成功 3 - 委托成功 4 - 委托失败 5 - 全部成交 6 - 部成部撤 7 - 全部撤单
  58. Ordertime time.Time `json:"ordertime" xorm:"'ORDERTIME'"` // 委托时间
  59. Updatetime time.Time `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间
  60. Mhpinnerorderid int64 `json:"mhpinnerorderid" xorm:"'MHPINNERORDERID'"` // 接口平台委托单ID
  61. Mhprspcode int64 `json:"mhprspcode" xorm:"'MHPRSPCODE'"` // 渠道返回码
  62. Mhprsptext string `json:"mhprsptext" xorm:"'MHPRSPTEXT'"` // 渠道返回信息
  63. Optiontype int32 `json:"optiontype" xorm:"'OPTIONTYPE'"` // 期权类型 - 1:认购(看涨) 2:认沽(看跌)
  64. Premium float64 `json:"premium" xorm:"'PREMIUM'"` // 权利金
  65. Realoutorderid int64 `json:"realoutorderid" xorm:"'REALOUTORDERID'"` // 实际外部平台委托单ID
  66. Relatedcreateorderid int64 `json:"relatedcreateorderid" xorm:"'RELATEDCREATEORDERID'"` // 关联外部建仓委托单ID[平仓委托]
  67. Channeloperatetype int32 `json:"channeloperatetype" xorm:"'CHANNELOPERATETYPE'"` // 操作类型 - 1:正常委托 2:斩仓委托 3:强平委托
  68. Channelordersrc int32 `json:"channelordersrc" xorm:"'CHANNELORDERSRC'"` // 委托来源 - 1:客户端 2:风控服务 3:管理端 4:下单接口平台 5:交易服务 6:跟单服务 7:监控终端
  69. Operatorid int64 `json:"operatorid" xorm:"'OPERATORID'"` // 登录账号(LoginID)
  70. Clientordertime time.Time `json:"clientordertime" xorm:"'CLIENTORDERTIME'"` // 客户端委托时间
  71. Clientticket string `json:"clientticket" xorm:"'CLIENTTICKET'"` // 客户端流水号
  72. UUID string `json:"uuid" xorm:"'UUID'"` // 发起端唯一id
  73. Clienttype int32 `json:"clienttype" xorm:"'CLIENTTYPE'"` // 客户端类型 - 0:保留为未填终端类型 1:PC管理端 2:PC交易端 3:手机客户端_安卓 4:网页客户端 5:微信客户端 6:手机客户端_苹果 7:网上开户客户端 8:无效终端编号 9:报价终端(中江) 10;监控终端
  74. Sessionid int64 `json:"sessionid" xorm:"'SESSIONID'"` // 会话ID
  75. }
  76. // TableName is HEDGE_OUTORDERDETAIL
  77. func (Hedgeoutorderdetail) TableName() string {
  78. return "HEDGE_OUTORDERDETAIL"
  79. }
  80. // Hedgeouttradedetail 对冲外部成交单表 - 导历史
  81. type Hedgeouttradedetail struct {
  82. Outtradeid int64 `json:"outtradeid" xorm:"'OUTTRADEID'" binding:"required"` // 外部成交单ID(114+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
  83. Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd)
  84. Relatedoutorderid int64 `json:"relatedoutorderid" xorm:"'RELATEDOUTORDERID'"` // 关联外部委托单ID
  85. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 资金账号[外部母账户]
  86. Hedgeaccountcode string `json:"hedgeaccountcode" xorm:"'HEDGEACCOUNTCODE'"` // 对冲账号
  87. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  88. Hedgegoodsid int64 `json:"hedgegoodsid" xorm:"'HEDGEGOODSID'"` // 对冲合约ID
  89. Buyorsell int32 `json:"buyorsell" xorm:"'BUYORSELL'"` // 买卖方向 - 0:买 1:卖
  90. Channelbuildtype int32 `json:"channelbuildtype" xorm:"'CHANNELBUILDTYPE'"` // 开平标志- 0:无 1:建仓 2:平仓
  91. Closetype int32 `json:"closetype" xorm:"'CLOSETYPE'"` // 平仓方式 - 0:无 1:平今 2:平昨
  92. Hedgeflag int32 `json:"hedgeflag" xorm:"'HEDGEFLAG'"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利
  93. Tradeprice float64 `json:"tradeprice" xorm:"'TRADEPRICE'"` // 成交价格
  94. Tradeqty int64 `json:"tradeqty" xorm:"'TRADEQTY'"` // 成交数量
  95. Tradetime time.Time `json:"tradetime" xorm:"'TRADETIME'"` // 成交时间
  96. Relatedmhpinnerorderid int64 `json:"relatedmhpinnerorderid" xorm:"'RELATEDMHPINNERORDERID'"` // 接口平台委托单ID
  97. Mhpinnertradeid int64 `json:"mhpinnertradeid" xorm:"'MHPINNERTRADEID'"` // 接口平台成交单ID
  98. Hasinnerorder int32 `json:"hasinnerorder" xorm:"'HASINNERORDER'"` // 是否有内部单关联 - 0:无 1:有
  99. Isvalid int32 `json:"isvalid" xorm:"'ISVALID'"` // 是否有效 - 0:无效 1:有效
  100. Optiontype int32 `json:"optiontype" xorm:"'OPTIONTYPE'"` // 期权类型 - 1:认购(看涨) 2:认沽(看跌)
  101. Premium float64 `json:"premium" xorm:"'PREMIUM'"` // 权利金
  102. Tradetype int32 `json:"tradetype" xorm:"'TRADETYPE'"` // 成交类别 - 1:正常委托成交3:修正持仓成交
  103. }
  104. // TableName is HEDGE_OUTTRADEDETAIL
  105. func (Hedgeouttradedetail) TableName() string {
  106. return "HEDGE_OUTTRADEDETAIL"
  107. }
  108. // Hedgeinnerholderdetail 对冲内部持仓单表 - 导历史
  109. type Hedgeinnerholderdetail struct {
  110. Tradeid int64 `json:"tradeid" xorm:"'TRADEID'" binding:"required"` // 成交单号(108+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
  111. Buyorsell int32 `json:"buyorsell" xorm:"'BUYORSELL'" binding:"required"` // 方向 - 0:买 1:卖
  112. Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd)
  113. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  114. Goodsid int32 `json:"goodsid" xorm:"'GOODSID'"` // 商品ID
  115. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 账号ID
  116. Openqty int64 `json:"openqty" xorm:"'OPENQTY'"` // 建仓数量
  117. Holderqty int64 `json:"holderqty" xorm:"'HOLDERQTY'"` // 持仓数量
  118. Freezeqty int64 `json:"freezeqty" xorm:"'FREEZEQTY'"` // 冻结数量 - 按单平使用
  119. Openprice float64 `json:"openprice" xorm:"'OPENPRICE'"` // 建仓价格
  120. Holderprice float64 `json:"holderprice" xorm:"'HOLDERPRICE'"` // 持仓价格
  121. Tradeamount float64 `json:"tradeamount" xorm:"'TRADEAMOUNT'"` // 成交金额[账户]
  122. Holderamount float64 `json:"holderamount" xorm:"'HOLDERAMOUNT'"` // 持仓金额 [商品币种]
  123. Releaseamount float64 `json:"releaseamount" xorm:"'RELEASEAMOUNT'"` // 释放持仓金额[商品币种]
  124. Holderdays int32 `json:"holderdays" xorm:"'HOLDERDAYS'"` // 剩余冻结天数
  125. Tradetime time.Time `json:"tradetime" xorm:"'TRADETIME'"` // 交易时间
  126. Parentaccountid int64 `json:"parentaccountid" xorm:"'PARENTACCOUNTID'"` // 所属母账户
  127. }
  128. // TableName is HEDGE_INNERHOLDERDETAIL
  129. func (Hedgeinnerholderdetail) TableName() string {
  130. return "HEDGE_INNERHOLDERDETAIL"
  131. }
  132. // Hedgeinnerorderdetail 对冲内部委托单表 - 导历史
  133. type Hedgeinnerorderdetail struct {
  134. Orderid int64 `json:"orderid" xorm:"'ORDERID'" binding:"required"` // 委托单号(107+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
  135. Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd)
  136. Channelbuildtype int32 `json:"channelbuildtype" xorm:"'CHANNELBUILDTYPE'"` // 开平标志 - 0:无 1:建仓 2:平仓
  137. Closetype int32 `json:"closetype" xorm:"'CLOSETYPE'"` // 平仓方式 - 0:无 1:平今 2:平昨
  138. Hedgeflag int32 `json:"hedgeflag" xorm:"'HEDGEFLAG'"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利
  139. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  140. Goodsid int32 `json:"goodsid" xorm:"'GOODSID'"` // 商品ID
  141. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 账户ID
  142. Buyorsell int32 `json:"buyorsell" xorm:"'BUYORSELL'"` // 买卖 - 0:买 1:卖
  143. Pricemode int32 `json:"pricemode" xorm:"'PRICEMODE'"` // 取价方式 - 1:市价 2: 限价
  144. Orderprice float64 `json:"orderprice" xorm:"'ORDERPRICE'"` // 委托价格(账户)
  145. Openorderqty int64 `json:"openorderqty" xorm:"'OPENORDERQTY'"` // 委托数量
  146. Opentradeqty int64 `json:"opentradeqty" xorm:"'OPENTRADEQTY'"` // 成交数量
  147. Opencancelqty int64 `json:"opencancelqty" xorm:"'OPENCANCELQTY'"` // 撤单数量
  148. Openfailqty int64 `json:"openfailqty" xorm:"'OPENFAILQTY'"` // 失败数量
  149. Opensuccessqty int64 `json:"opensuccessqty" xorm:"'OPENSUCCESSQTY'"` // 建仓委托成功数量
  150. Closeorderqty int64 `json:"closeorderqty" xorm:"'CLOSEORDERQTY'"` // 委托数量
  151. Closetradeqty int64 `json:"closetradeqty" xorm:"'CLOSETRADEQTY'"` // 成交数量
  152. Closecancelqty int64 `json:"closecancelqty" xorm:"'CLOSECANCELQTY'"` // 撤单数量
  153. Closefailqty int64 `json:"closefailqty" xorm:"'CLOSEFAILQTY'"` // 失败数量
  154. Closesuccessqty int64 `json:"closesuccessqty" xorm:"'CLOSESUCCESSQTY'"` // 委托成功数量
  155. Openfreezemargin float64 `json:"openfreezemargin" xorm:"'OPENFREEZEMARGIN'"` // 冻结保证金(冻结交易金额)
  156. Openunfreezemargin float64 `json:"openunfreezemargin" xorm:"'OPENUNFREEZEMARGIN'"` // 解冻保证金
  157. Openfreezecharge float64 `json:"openfreezecharge" xorm:"'OPENFREEZECHARGE'"` // 建仓冻结手续费(账户)
  158. Openunfreezecharge float64 `json:"openunfreezecharge" xorm:"'OPENUNFREEZECHARGE'"` // 建仓解冻手续费(账户)
  159. Validtype int32 `json:"validtype" xorm:"'VALIDTYPE'"` // 有效类型 - 1当日有效
  160. Validtime time.Time `json:"validtime" xorm:"'VALIDTIME'"` // 有效期限
  161. Channeloperatetype int32 `json:"channeloperatetype" xorm:"'CHANNELOPERATETYPE'"` // 操作类型 - 1:正常委托 2:斩仓委托 3:强平委托
  162. Ordertime time.Time `json:"ordertime" xorm:"'ORDERTIME'"` // 委托时间
  163. Channelordersrc int32 `json:"channelordersrc" xorm:"'CHANNELORDERSRC'"` // 委托来源 - 1:客户端 2:风控服务 3:管理端 4:下单接口平台 5:交易服务 6:跟单服务 7:监控终端
  164. Channelinnerorderstatus int32 `json:"channelinnerorderstatus" xorm:"'CHANNELINNERORDERSTATUS'"` // 委托状态 - 1:委托请求 2:冻结成功 3:委托失败 4:委托部成部失败 5:委托成功 6:全部撤销 7:部成部撤 8:部成部撤部失败 9:全部成交
  165. Operatorid int64 `json:"operatorid" xorm:"'OPERATORID'"` // 登录账号(LoginID)
  166. Updatetime time.Time `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间
  167. Clientordertime time.Time `json:"clientordertime" xorm:"'CLIENTORDERTIME'"` // 客户端委托时间
  168. Clientticket string `json:"clientticket" xorm:"'CLIENTTICKET'"` // 客户端流水号
  169. UUID string `json:"uuid" xorm:"'UUID'"` // 发起端唯一id
  170. Clienttype int32 `json:"clienttype" xorm:"'CLIENTTYPE'"` // 客户端类型 - 0:保留为未填终端类型 1:PC管理端 2:PC交易端 3:手机客户端_安卓 4:网页客户端 5:微信客户端 6:手机客户端_苹果 7:网上开户客户端 8:无效终端编号 9:报价终端(中江) 10;监控终端
  171. Retcode int32 `json:"retcode" xorm:"'RETCODE'"` // 错误代码
  172. Marginalgorithm int32 `json:"marginalgorithm" xorm:"'MARGINALGORITHM'"` // 保证金收取方式 1:比率 2:固定
  173. Marginvalue float64 `json:"marginvalue" xorm:"'MARGINVALUE'"` // 即市保证金设置值
  174. Openfeealgorithm int32 `json:"openfeealgorithm" xorm:"'OPENFEEALGORITHM'"` // 建仓手续费收取方式 1:比率 2:固定
  175. Openchargevalue float64 `json:"openchargevalue" xorm:"'OPENCHARGEVALUE'"` // 建仓手续费设置值
  176. Closefeealgorithm int32 `json:"closefeealgorithm" xorm:"'CLOSEFEEALGORITHM'"` // 平仓手续费收取方式 1:比率 2:固定
  177. Closechargevalue float64 `json:"closechargevalue" xorm:"'CLOSECHARGEVALUE'"` // 平仓手续费设置值
  178. Accountcurrencyid int32 `json:"accountcurrencyid" xorm:"'ACCOUNTCURRENCYID'"` // 账户币种ID
  179. Goodscurrencyid int32 `json:"goodscurrencyid" xorm:"'GOODSCURRENCYID'"` // 商品币种ID
  180. Margincurrencyid int32 `json:"margincurrencyid" xorm:"'MARGINCURRENCYID'"` // 保证金币种ID 比率时等于账户币种
  181. Marginrate float64 `json:"marginrate" xorm:"'MARGINRATE'"` // 保证金汇率-比率时等于1
  182. Curexchangerate float64 `json:"curexchangerate" xorm:"'CUREXCHANGERATE'"` // 当前汇率
  183. Goodsorderprice float64 `json:"goodsorderprice" xorm:"'GOODSORDERPRICE'"` // 委托价格(商品)
  184. Openfreezemargin2 float64 `json:"openfreezemargin2" xorm:"'OPENFREEZEMARGIN2'"` // 建仓冻结保证金(保证金/商品)
  185. Openfreezecharge2 float64 `json:"openfreezecharge2" xorm:"'OPENFREEZECHARGE2'"` // 建仓冻结手续费(商品)
  186. Openunfreezemargin2 float64 `json:"openunfreezemargin2" xorm:"'OPENUNFREEZEMARGIN2'"` // 建仓解冻保证金(保证金/商品)
  187. Openunfreezecharge2 float64 `json:"openunfreezecharge2" xorm:"'OPENUNFREEZECHARGE2'"` // 建仓解冻手续费(商品)
  188. Parentaccountid int64 `json:"parentaccountid" xorm:"'PARENTACCOUNTID'"` // 所属母账户
  189. Sessionid int64 `json:"sessionid" xorm:"'SESSIONID'"` // 会话ID
  190. }
  191. // TableName is HEDGE_INNERORDERDETAIL
  192. func (Hedgeinnerorderdetail) TableName() string {
  193. return "HEDGE_INNERORDERDETAIL"
  194. }
  195. // Hedgeinnertradedetail 对冲内部成交单表 - 导历史
  196. type Hedgeinnertradedetail struct {
  197. Tradeid int64 `json:"tradeid" xorm:"'TRADEID'" binding:"required"` // 成交单号(108+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
  198. Buyorsell int32 `json:"buyorsell" xorm:"'BUYORSELL'" binding:"required"` // 方向 - 0:买 1:卖
  199. Orderid int64 `json:"orderid" xorm:"'ORDERID'"` // 委托单号
  200. Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd)
  201. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 账号ID
  202. Goodsid int32 `json:"goodsid" xorm:"'GOODSID'"` // 商品ID
  203. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  204. Tradetime time.Time `json:"tradetime" xorm:"'TRADETIME'"` // 成交时间
  205. Tradeprice float64 `json:"tradeprice" xorm:"'TRADEPRICE'"` // 成交价格
  206. Tradeqty int64 `json:"tradeqty" xorm:"'TRADEQTY'"` // 成交数量
  207. Tradeamount float64 `json:"tradeamount" xorm:"'TRADEAMOUNT'"` // 成交金额(账户)
  208. Closepl float64 `json:"closepl" xorm:"'CLOSEPL'"` // 平仓盈亏(账户)
  209. Opencharge float64 `json:"opencharge" xorm:"'OPENCHARGE'"` // 建仓手续费(账户)
  210. Closecharge float64 `json:"closecharge" xorm:"'CLOSECHARGE'"` // 平仓手续费(账户)
  211. Tradetype int32 `json:"tradetype" xorm:"'TRADETYPE'"` // 成交类别 - 1:正常委托成交 2:风控斩仓成交 3:修正持仓成交 4:管理端斩仓成交
  212. Channelbuildtype int32 `json:"channelbuildtype" xorm:"'CHANNELBUILDTYPE'"` // 委托单据类型 0:无 1:建仓 2:平仓
  213. Closetype int32 `json:"closetype" xorm:"'CLOSETYPE'"` // 平仓方式 - 0:无 1:平今 2:平昨
  214. Hedgeflag int32 `json:"hedgeflag" xorm:"'HEDGEFLAG'"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利
  215. Openqty int64 `json:"openqty" xorm:"'OPENQTY'"` // 开仓数量(先建后平操作 需要记录)
  216. Closeqty int64 `json:"closeqty" xorm:"'CLOSEQTY'"` // 平仓数量(先建后平操作 需要记录)
  217. Status int32 `json:"status" xorm:"'STATUS'"` // 处理状态 - 1:待处理 2:已处理 3:处理失败
  218. Isreckoned int32 `json:"isreckoned" xorm:"'ISRECKONED'"` // 是否结算 - 0:未结算 1:已结算
  219. Openfeealgorithm int32 `json:"openfeealgorithm" xorm:"'OPENFEEALGORITHM'"` // 建仓手续费收取方式 1:比率 2:固定
  220. Openchargevalue float64 `json:"openchargevalue" xorm:"'OPENCHARGEVALUE'"` // 建仓手续费设置值
  221. Closefeealgorithm int32 `json:"closefeealgorithm" xorm:"'CLOSEFEEALGORITHM'"` // 平仓手续费收取方式 1:比率 2:固定
  222. Closechargevalue float64 `json:"closechargevalue" xorm:"'CLOSECHARGEVALUE'"` // 平仓手续费设置值
  223. Accountcurrencyid int32 `json:"accountcurrencyid" xorm:"'ACCOUNTCURRENCYID'"` // 账户币种ID
  224. Goodscurrencyid int32 `json:"goodscurrencyid" xorm:"'GOODSCURRENCYID'"` // 商品币种ID
  225. Curexchangerate float64 `json:"curexchangerate" xorm:"'CUREXCHANGERATE'"` // 当前汇率
  226. Opencharge2 float64 `json:"opencharge2" xorm:"'OPENCHARGE2'"` // 建仓手续费(商品)
  227. Closecharge2 float64 `json:"closecharge2" xorm:"'CLOSECHARGE2'"` // 平仓手续费(商品)
  228. Closepl2 float64 `json:"closepl2" xorm:"'CLOSEPL2'"` // 平仓盈亏(商品)
  229. Closepl3 float64 `json:"closepl3" xorm:"'CLOSEPL3'"` // 平仓盈亏(账户)(逐笔)
  230. Closepl4 float64 `json:"closepl4" xorm:"'CLOSEPL4'"` // 平仓盈亏(商品)(逐笔)
  231. Extenalopenfeealgorithm int32 `json:"extenalopenfeealgorithm" xorm:"'EXTENALOPENFEEALGORITHM'"` // 建仓手续费收取方式(外部配置) 1:比率 2:固定
  232. Extenalopenchargevalue float64 `json:"extenalopenchargevalue" xorm:"'EXTENALOPENCHARGEVALUE'"` // 建仓手续费设置值
  233. Extenalclosefeealgorithm int32 `json:"extenalclosefeealgorithm" xorm:"'EXTENALCLOSEFEEALGORITHM'"` // 平仓手续费收取方式 1:比率 2:固定
  234. Extenalclosechargevalue float64 `json:"extenalclosechargevalue" xorm:"'EXTENALCLOSECHARGEVALUE'"` // 平仓手续费设置值
  235. Extenalopencharge float64 `json:"extenalopencharge" xorm:"'EXTENALOPENCHARGE'"` // 建仓手续费(商品)(外部)
  236. Extenalclosecharge float64 `json:"extenalclosecharge" xorm:"'EXTENALCLOSECHARGE'"` // 平仓手续费(商品)(外部)
  237. Parentaccountid int64 `json:"parentaccountid" xorm:"'PARENTACCOUNTID'"` // 所属母账户
  238. Relatedouttradeid int64 `json:"relatedouttradeid" xorm:"'RELATEDOUTTRADEID'"` // 关联外部成交单ID
  239. }
  240. // TableName is HEDGE_INNERTRADEDETAIL
  241. func (Hedgeinnertradedetail) TableName() string {
  242. return "HEDGE_INNERTRADEDETAIL"
  243. }
  244. // GetHedgeOutTradePositions 获取外部持仓头寸信息
  245. func GetHedgeOutTradePositions(accountID int, marketID int) ([]Hedgeouttradeposition, error) {
  246. engine := db.GetEngine()
  247. hedgeOutTradePositions := make([]Hedgeouttradeposition, 0)
  248. session := engine.Where("ACCOUNTID = ?", accountID)
  249. if marketID != 0 {
  250. session = session.And("MARKETID = ?", marketID)
  251. }
  252. if err := session.Find(&hedgeOutTradePositions); err != nil {
  253. return nil, err
  254. }
  255. return hedgeOutTradePositions, nil
  256. }
  257. // GetHedgeInnerHolderDetails 获取指定商品和方向的通道交易内部持仓明细数据
  258. func GetHedgeInnerHolderDetails(accountID, goodsID, buyOrSell int) ([]Hedgeinnerholderdetail, error) {
  259. hedgeInnerHolderDetails := make([]Hedgeinnerholderdetail, 0)
  260. if err := db.GetEngine().
  261. Where("GOODSID = ?", goodsID).
  262. And("BUYORSELL = ?", buyOrSell).
  263. And("ACCOUNTID = ?", accountID).
  264. Find(&hedgeInnerHolderDetails); err != nil {
  265. return nil, err
  266. }
  267. return hedgeInnerHolderDetails, nil
  268. }
  269. // QueryHedgeOrderDetailRsp 企业风管委托单查询返回模型
  270. type QueryHedgeOrderDetailRsp struct {
  271. Orderid string `json:"orderid"` // 委托单号(107+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
  272. Tradedate string `json:"tradedate"` // 交易日(yyyyMMdd)
  273. Channelbuildtype int32 `json:"channelbuildtype"` // 开平标志 - 0:无 1:建仓 2:平仓
  274. Closetype int32 `json:"closetype"` // 平仓方式 - 0:无 1:平今 2:平昨
  275. Marketid int32 `json:"marketid"` // 市场ID
  276. Goodsid int32 `json:"goodsid"` // 商品ID
  277. Accountid int64 `json:"accountid"` // 账户ID
  278. Buyorsell int32 `json:"buyorsell"` // 买卖 - 0:买 1:卖
  279. Pricemode int32 `json:"pricemode"` // 取价方式 - 1:市价 2: 限价
  280. Orderprice float64 `json:"orderprice"` // 委托价格(账户)
  281. Orderqty int64 `json:"orderqty"` // 委托数量
  282. Tradeqty int64 `json:"tradeqty"` // 成交数量
  283. Openfreezemargin float64 `json:"openfreezemargin"` // 冻结保证金(冻结交易金额)
  284. Channeloperatetype int32 `json:"channeloperatetype"` // 操作类型 - 1:正常委托 2:斩仓委托 3:强平委托
  285. Ordertime time.Time `json:"ordertime"` // 委托时间
  286. Channelinnerorderstatus int32 `json:"channelinnerorderstatus"` // 委托状态 - 1:委托请求 2:冻结成功 3:委托失败 4:委托部成部失败 5:委托成功 6:全部撤销 7:部成部撤 8:部成部撤部失败 9:全部成交
  287. Curexchangerate float64 `json:"curexchangerate"` // 当前汇率
  288. Goodscode string `json:"goodscode"` // 商品代码(内部)
  289. Goodsname string `json:"goodsname"` // 商品名称
  290. Exchangefullname string `json:"exchangefullname" xorm:"'EXCHANGEFULLNAME'"` // 外部交易所全称
  291. }
  292. // GetHedgeInnerOrderDetails 获取指定资金账号的通道交易内部委托单信息
  293. func GetHedgeInnerOrderDetails(accountID int) ([]QueryHedgeOrderDetailRsp, error) {
  294. type orderDetail struct {
  295. Orderid int64 `json:"orderid" xorm:"'ORDERID'" binding:"required"` // 委托单号(107+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
  296. Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd)
  297. Channelbuildtype int32 `json:"channelbuildtype" xorm:"'CHANNELBUILDTYPE'"` // 开平标志 - 0:无 1:建仓 2:平仓
  298. Closetype int32 `json:"closetype" xorm:"'CLOSETYPE'"` // 平仓方式 - 0:无 1:平今 2:平昨
  299. Hedgeflag int32 `json:"hedgeflag" xorm:"'HEDGEFLAG'"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利
  300. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  301. Goodsid int32 `json:"goodsid" xorm:"'GOODSID'"` // 商品ID
  302. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 账户ID
  303. Buyorsell int32 `json:"buyorsell" xorm:"'BUYORSELL'"` // 买卖 - 0:买 1:卖
  304. Pricemode int32 `json:"pricemode" xorm:"'PRICEMODE'"` // 取价方式 - 1:市价 2: 限价
  305. Orderprice float64 `json:"orderprice" xorm:"'ORDERPRICE'"` // 委托价格(账户)
  306. Openorderqty int64 `json:"openorderqty" xorm:"'OPENORDERQTY'"` // 委托数量
  307. Opentradeqty int64 `json:"opentradeqty" xorm:"'OPENTRADEQTY'"` // 成交数量
  308. Opencancelqty int64 `json:"opencancelqty" xorm:"'OPENCANCELQTY'"` // 撤单数量
  309. Openfailqty int64 `json:"openfailqty" xorm:"'OPENFAILQTY'"` // 失败数量
  310. Opensuccessqty int64 `json:"opensuccessqty" xorm:"'OPENSUCCESSQTY'"` // 建仓委托成功数量
  311. Closeorderqty int64 `json:"closeorderqty" xorm:"'CLOSEORDERQTY'"` // 委托数量
  312. Closetradeqty int64 `json:"closetradeqty" xorm:"'CLOSETRADEQTY'"` // 成交数量
  313. Closecancelqty int64 `json:"closecancelqty" xorm:"'CLOSECANCELQTY'"` // 撤单数量
  314. Closefailqty int64 `json:"closefailqty" xorm:"'CLOSEFAILQTY'"` // 失败数量
  315. Closesuccessqty int64 `json:"closesuccessqty" xorm:"'CLOSESUCCESSQTY'"` // 委托成功数量
  316. Openfreezemargin float64 `json:"openfreezemargin" xorm:"'OPENFREEZEMARGIN'"` // 冻结保证金(冻结交易金额)
  317. Openunfreezemargin float64 `json:"openunfreezemargin" xorm:"'OPENUNFREEZEMARGIN'"` // 解冻保证金
  318. Openfreezecharge float64 `json:"openfreezecharge" xorm:"'OPENFREEZECHARGE'"` // 建仓冻结手续费(账户)
  319. Openunfreezecharge float64 `json:"openunfreezecharge" xorm:"'OPENUNFREEZECHARGE'"` // 建仓解冻手续费(账户)
  320. Validtype int32 `json:"validtype" xorm:"'VALIDTYPE'"` // 有效类型 - 1当日有效
  321. Validtime time.Time `json:"validtime" xorm:"'VALIDTIME'"` // 有效期限
  322. Channeloperatetype int32 `json:"channeloperatetype" xorm:"'CHANNELOPERATETYPE'"` // 操作类型 - 1:正常委托 2:斩仓委托 3:强平委托
  323. Ordertime time.Time `json:"ordertime" xorm:"'ORDERTIME'"` // 委托时间
  324. Channelordersrc int32 `json:"channelordersrc" xorm:"'CHANNELORDERSRC'"` // 委托来源 - 1:客户端 2:风控服务 3:管理端 4:下单接口平台 5:交易服务 6:跟单服务 7:监控终端
  325. Channelinnerorderstatus int32 `json:"channelinnerorderstatus" xorm:"'CHANNELINNERORDERSTATUS'"` // 委托状态 - 1:委托请求 2:冻结成功 3:委托失败 4:委托部成部失败 5:委托成功 6:全部撤销 7:部成部撤 8:部成部撤部失败 9:全部成交
  326. Operatorid int64 `json:"operatorid" xorm:"'OPERATORID'"` // 登录账号(LoginID)
  327. Updatetime time.Time `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间
  328. Clientordertime time.Time `json:"clientordertime" xorm:"'CLIENTORDERTIME'"` // 客户端委托时间
  329. Clientticket string `json:"clientticket" xorm:"'CLIENTTICKET'"` // 客户端流水号
  330. UUID string `json:"uuid" xorm:"'UUID'"` // 发起端唯一id
  331. Clienttype int32 `json:"clienttype" xorm:"'CLIENTTYPE'"` // 客户端类型 - 0:保留为未填终端类型 1:PC管理端 2:PC交易端 3:手机客户端_安卓 4:网页客户端 5:微信客户端 6:手机客户端_苹果 7:网上开户客户端 8:无效终端编号 9:报价终端(中江) 10;监控终端
  332. Retcode int32 `json:"retcode" xorm:"'RETCODE'"` // 错误代码
  333. Marginalgorithm int32 `json:"marginalgorithm" xorm:"'MARGINALGORITHM'"` // 保证金收取方式 1:比率 2:固定
  334. Marginvalue float64 `json:"marginvalue" xorm:"'MARGINVALUE'"` // 即市保证金设置值
  335. Openfeealgorithm int32 `json:"openfeealgorithm" xorm:"'OPENFEEALGORITHM'"` // 建仓手续费收取方式 1:比率 2:固定
  336. Openchargevalue float64 `json:"openchargevalue" xorm:"'OPENCHARGEVALUE'"` // 建仓手续费设置值
  337. Closefeealgorithm int32 `json:"closefeealgorithm" xorm:"'CLOSEFEEALGORITHM'"` // 平仓手续费收取方式 1:比率 2:固定
  338. Closechargevalue float64 `json:"closechargevalue" xorm:"'CLOSECHARGEVALUE'"` // 平仓手续费设置值
  339. Accountcurrencyid int32 `json:"accountcurrencyid" xorm:"'ACCOUNTCURRENCYID'"` // 账户币种ID
  340. Goodscurrencyid int32 `json:"goodscurrencyid" xorm:"'GOODSCURRENCYID'"` // 商品币种ID
  341. Margincurrencyid int32 `json:"margincurrencyid" xorm:"'MARGINCURRENCYID'"` // 保证金币种ID 比率时等于账户币种
  342. Marginrate float64 `json:"marginrate" xorm:"'MARGINRATE'"` // 保证金汇率-比率时等于1
  343. Curexchangerate float64 `json:"curexchangerate" xorm:"'CUREXCHANGERATE'"` // 当前汇率
  344. Goodsorderprice float64 `json:"goodsorderprice" xorm:"'GOODSORDERPRICE'"` // 委托价格(商品)
  345. Openfreezemargin2 float64 `json:"openfreezemargin2" xorm:"'OPENFREEZEMARGIN2'"` // 建仓冻结保证金(保证金/商品)
  346. Openfreezecharge2 float64 `json:"openfreezecharge2" xorm:"'OPENFREEZECHARGE2'"` // 建仓冻结手续费(商品)
  347. Openunfreezemargin2 float64 `json:"openunfreezemargin2" xorm:"'OPENUNFREEZEMARGIN2'"` // 建仓解冻保证金(保证金/商品)
  348. Openunfreezecharge2 float64 `json:"openunfreezecharge2" xorm:"'OPENUNFREEZECHARGE2'"` // 建仓解冻手续费(商品)
  349. Parentaccountid int64 `json:"parentaccountid" xorm:"'PARENTACCOUNTID'"` // 所属母账户
  350. Sessionid int64 `json:"sessionid" xorm:"'SESSIONID'"` // 会话ID
  351. Orderidstr string `xorm:"ORDERIDSTR"`
  352. Goodscode string `xorm:"GOODSCODE"`
  353. Goodsname string `xorm:"GOODSNAME"`
  354. Exchangefullname string `xorm:"'EXCHANGEFULLNAME'"`
  355. }
  356. hedgeInnerOrderDetails := make([]orderDetail, 0)
  357. if err := db.GetEngine().Table("HEDGE_INNERORDERDETAIL T").
  358. Select("to_char(T.ORDERID) ORDERIDSTR, G.GOODSCODE, G.GOODSNAME, T.*, EX.EXCHANGEFULLNAME").
  359. Join("LEFT", "GOODS G", "G.GOODSID = T.GOODSID").
  360. Join("LEFT", "GOODSGROUP GG", "GG.GOODSGROUPID = G.GOODSGROUPID").
  361. Join("LEFT", "EXTERNALEXCHANGE EX", "GG.EXEXCHANGEID = EX.AUTOID").
  362. Where("T.ACCOUNTID = ?", accountID).Desc("T.ORDERTIME").
  363. Find(&hedgeInnerOrderDetails); err != nil {
  364. return nil, err
  365. }
  366. rsp := make([]QueryHedgeOrderDetailRsp, 0)
  367. for _, v := range hedgeInnerOrderDetails {
  368. // 内部委托单分建平
  369. orderQty := v.Openorderqty
  370. tradeQty := v.Opentradeqty
  371. if v.Channelbuildtype == 2 {
  372. orderQty = v.Closeorderqty
  373. tradeQty = v.Closetradeqty
  374. }
  375. rsp = append(rsp, QueryHedgeOrderDetailRsp{
  376. Orderid: v.Orderidstr,
  377. Tradedate: v.Tradedate,
  378. Channelbuildtype: v.Channelbuildtype,
  379. Closetype: v.Closetype,
  380. Marketid: v.Marketid,
  381. Goodsid: v.Goodsid,
  382. Accountid: v.Accountid,
  383. Buyorsell: v.Buyorsell,
  384. Pricemode: v.Pricemode,
  385. Orderprice: v.Orderprice,
  386. Orderqty: orderQty,
  387. Tradeqty: tradeQty,
  388. Openfreezemargin: v.Openfreezemargin,
  389. Channeloperatetype: v.Channeloperatetype,
  390. Ordertime: v.Ordertime,
  391. Channelinnerorderstatus: v.Channelinnerorderstatus,
  392. Curexchangerate: v.Curexchangerate,
  393. Goodscode: v.Goodscode,
  394. Goodsname: v.Goodsname,
  395. Exchangefullname: v.Exchangefullname,
  396. })
  397. }
  398. return rsp, nil
  399. }
  400. // GetHisHedgeInnerOrderDetails 获取指定资金账号的通道交易历史内部委托单信息
  401. func GetHisHedgeInnerOrderDetails(accountID int, startDate, endDate string) ([]QueryHedgeOrderDetailRsp, error) {
  402. type orderDetail struct {
  403. Orderid int64 `json:"orderid" xorm:"'ORDERID'" binding:"required"` // 委托单号(107+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
  404. Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd)
  405. Channelbuildtype int32 `json:"channelbuildtype" xorm:"'CHANNELBUILDTYPE'"` // 开平标志 - 0:无 1:建仓 2:平仓
  406. Closetype int32 `json:"closetype" xorm:"'CLOSETYPE'"` // 平仓方式 - 0:无 1:平今 2:平昨
  407. Hedgeflag int32 `json:"hedgeflag" xorm:"'HEDGEFLAG'"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利
  408. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  409. Goodsid int32 `json:"goodsid" xorm:"'GOODSID'"` // 商品ID
  410. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 账户ID
  411. Buyorsell int32 `json:"buyorsell" xorm:"'BUYORSELL'"` // 买卖 - 0:买 1:卖
  412. Pricemode int32 `json:"pricemode" xorm:"'PRICEMODE'"` // 取价方式 - 1:市价 2: 限价
  413. Orderprice float64 `json:"orderprice" xorm:"'ORDERPRICE'"` // 委托价格(账户)
  414. Openorderqty int64 `json:"openorderqty" xorm:"'OPENORDERQTY'"` // 委托数量
  415. Opentradeqty int64 `json:"opentradeqty" xorm:"'OPENTRADEQTY'"` // 成交数量
  416. Opencancelqty int64 `json:"opencancelqty" xorm:"'OPENCANCELQTY'"` // 撤单数量
  417. Openfailqty int64 `json:"openfailqty" xorm:"'OPENFAILQTY'"` // 失败数量
  418. Opensuccessqty int64 `json:"opensuccessqty" xorm:"'OPENSUCCESSQTY'"` // 建仓委托成功数量
  419. Closeorderqty int64 `json:"closeorderqty" xorm:"'CLOSEORDERQTY'"` // 委托数量
  420. Closetradeqty int64 `json:"closetradeqty" xorm:"'CLOSETRADEQTY'"` // 成交数量
  421. Closecancelqty int64 `json:"closecancelqty" xorm:"'CLOSECANCELQTY'"` // 撤单数量
  422. Closefailqty int64 `json:"closefailqty" xorm:"'CLOSEFAILQTY'"` // 失败数量
  423. Closesuccessqty int64 `json:"closesuccessqty" xorm:"'CLOSESUCCESSQTY'"` // 委托成功数量
  424. Openfreezemargin float64 `json:"openfreezemargin" xorm:"'OPENFREEZEMARGIN'"` // 冻结保证金(冻结交易金额)
  425. Openunfreezemargin float64 `json:"openunfreezemargin" xorm:"'OPENUNFREEZEMARGIN'"` // 解冻保证金
  426. Openfreezecharge float64 `json:"openfreezecharge" xorm:"'OPENFREEZECHARGE'"` // 建仓冻结手续费(账户)
  427. Openunfreezecharge float64 `json:"openunfreezecharge" xorm:"'OPENUNFREEZECHARGE'"` // 建仓解冻手续费(账户)
  428. Validtype int32 `json:"validtype" xorm:"'VALIDTYPE'"` // 有效类型 - 1当日有效
  429. Validtime time.Time `json:"validtime" xorm:"'VALIDTIME'"` // 有效期限
  430. Channeloperatetype int32 `json:"channeloperatetype" xorm:"'CHANNELOPERATETYPE'"` // 操作类型 - 1:正常委托 2:斩仓委托 3:强平委托
  431. Ordertime time.Time `json:"ordertime" xorm:"'ORDERTIME'"` // 委托时间
  432. Channelordersrc int32 `json:"channelordersrc" xorm:"'CHANNELORDERSRC'"` // 委托来源 - 1:客户端 2:风控服务 3:管理端 4:下单接口平台 5:交易服务 6:跟单服务 7:监控终端
  433. Channelinnerorderstatus int32 `json:"channelinnerorderstatus" xorm:"'CHANNELINNERORDERSTATUS'"` // 委托状态 - 1:委托请求 2:冻结成功 3:委托失败 4:委托部成部失败 5:委托成功 6:全部撤销 7:部成部撤 8:部成部撤部失败 9:全部成交
  434. Operatorid int64 `json:"operatorid" xorm:"'OPERATORID'"` // 登录账号(LoginID)
  435. Updatetime time.Time `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间
  436. Clientordertime time.Time `json:"clientordertime" xorm:"'CLIENTORDERTIME'"` // 客户端委托时间
  437. Clientticket string `json:"clientticket" xorm:"'CLIENTTICKET'"` // 客户端流水号
  438. UUID string `json:"uuid" xorm:"'UUID'"` // 发起端唯一id
  439. Clienttype int32 `json:"clienttype" xorm:"'CLIENTTYPE'"` // 客户端类型 - 0:保留为未填终端类型 1:PC管理端 2:PC交易端 3:手机客户端_安卓 4:网页客户端 5:微信客户端 6:手机客户端_苹果 7:网上开户客户端 8:无效终端编号 9:报价终端(中江) 10;监控终端
  440. Retcode int32 `json:"retcode" xorm:"'RETCODE'"` // 错误代码
  441. Marginalgorithm int32 `json:"marginalgorithm" xorm:"'MARGINALGORITHM'"` // 保证金收取方式 1:比率 2:固定
  442. Marginvalue float64 `json:"marginvalue" xorm:"'MARGINVALUE'"` // 即市保证金设置值
  443. Openfeealgorithm int32 `json:"openfeealgorithm" xorm:"'OPENFEEALGORITHM'"` // 建仓手续费收取方式 1:比率 2:固定
  444. Openchargevalue float64 `json:"openchargevalue" xorm:"'OPENCHARGEVALUE'"` // 建仓手续费设置值
  445. Closefeealgorithm int32 `json:"closefeealgorithm" xorm:"'CLOSEFEEALGORITHM'"` // 平仓手续费收取方式 1:比率 2:固定
  446. Closechargevalue float64 `json:"closechargevalue" xorm:"'CLOSECHARGEVALUE'"` // 平仓手续费设置值
  447. Accountcurrencyid int32 `json:"accountcurrencyid" xorm:"'ACCOUNTCURRENCYID'"` // 账户币种ID
  448. Goodscurrencyid int32 `json:"goodscurrencyid" xorm:"'GOODSCURRENCYID'"` // 商品币种ID
  449. Margincurrencyid int32 `json:"margincurrencyid" xorm:"'MARGINCURRENCYID'"` // 保证金币种ID 比率时等于账户币种
  450. Marginrate float64 `json:"marginrate" xorm:"'MARGINRATE'"` // 保证金汇率-比率时等于1
  451. Curexchangerate float64 `json:"curexchangerate" xorm:"'CUREXCHANGERATE'"` // 当前汇率
  452. Goodsorderprice float64 `json:"goodsorderprice" xorm:"'GOODSORDERPRICE'"` // 委托价格(商品)
  453. Openfreezemargin2 float64 `json:"openfreezemargin2" xorm:"'OPENFREEZEMARGIN2'"` // 建仓冻结保证金(保证金/商品)
  454. Openfreezecharge2 float64 `json:"openfreezecharge2" xorm:"'OPENFREEZECHARGE2'"` // 建仓冻结手续费(商品)
  455. Openunfreezemargin2 float64 `json:"openunfreezemargin2" xorm:"'OPENUNFREEZEMARGIN2'"` // 建仓解冻保证金(保证金/商品)
  456. Openunfreezecharge2 float64 `json:"openunfreezecharge2" xorm:"'OPENUNFREEZECHARGE2'"` // 建仓解冻手续费(商品)
  457. Parentaccountid int64 `json:"parentaccountid" xorm:"'PARENTACCOUNTID'"` // 所属母账户
  458. Sessionid int64 `json:"sessionid" xorm:"'SESSIONID'"` // 会话ID
  459. Orderidstr string `xorm:"ORDERIDSTR"`
  460. Goodscode string `xorm:"GOODSCODE"`
  461. Goodsname string `xorm:"GOODSNAME"`
  462. Exchangefullname string `xorm:"'EXCHANGEFULLNAME'"`
  463. }
  464. hedgeInnerOrderDetails := make([]orderDetail, 0)
  465. session := db.GetEngine().Table("HIS_HEDGE_INNERORDERDETAIL T").
  466. Select("to_char(T.ORDERID) ORDERIDSTR, G.GOODSCODE, G.GOODSNAME, T.*, EX.EXCHANGEFULLNAME").
  467. Join("LEFT", "GOODS G", "G.GOODSID = T.GOODSID").
  468. Join("LEFT", "GOODSGROUP GG", "GG.GOODSGROUPID = G.GOODSGROUPID").
  469. Join("LEFT", "EXTERNALEXCHANGE EX", "GG.EXEXCHANGEID = EX.AUTOID").
  470. Where("T.ISVALIDDATA = 1 and T.ACCOUNTID = ?", accountID).Desc("T.ORDERTIME")
  471. if len(startDate) > 0 {
  472. session = session.And(fmt.Sprintf("to_date(T.HISTRADEDATE,'yyyyMMdd') >= to_date('%s','yyyy-MM-dd')", startDate))
  473. }
  474. if len(endDate) > 0 {
  475. session = session.And(fmt.Sprintf("to_date(T.HISTRADEDATE,'yyyyMMdd') <= to_date('%s','yyyy-MM-dd')", endDate))
  476. }
  477. if err := session.Find(&hedgeInnerOrderDetails); err != nil {
  478. return nil, err
  479. }
  480. rsp := make([]QueryHedgeOrderDetailRsp, 0)
  481. for _, v := range hedgeInnerOrderDetails {
  482. // 内部委托单分建平
  483. orderQty := v.Openorderqty
  484. tradeQty := v.Opentradeqty
  485. if v.Channelbuildtype == 2 {
  486. orderQty = v.Closeorderqty
  487. tradeQty = v.Closetradeqty
  488. }
  489. rsp = append(rsp, QueryHedgeOrderDetailRsp{
  490. Orderid: v.Orderidstr,
  491. Tradedate: v.Tradedate,
  492. Channelbuildtype: v.Channelbuildtype,
  493. Closetype: v.Closetype,
  494. Marketid: v.Marketid,
  495. Goodsid: v.Goodsid,
  496. Accountid: v.Accountid,
  497. Buyorsell: v.Buyorsell,
  498. Pricemode: v.Pricemode,
  499. Orderprice: v.Orderprice,
  500. Orderqty: orderQty,
  501. Tradeqty: tradeQty,
  502. Openfreezemargin: v.Openfreezemargin,
  503. Channeloperatetype: v.Channeloperatetype,
  504. Ordertime: v.Ordertime,
  505. Channelinnerorderstatus: v.Channelinnerorderstatus,
  506. Curexchangerate: v.Curexchangerate,
  507. Goodscode: v.Goodscode,
  508. Goodsname: v.Goodsname,
  509. Exchangefullname: v.Exchangefullname,
  510. })
  511. }
  512. return rsp, nil
  513. }
  514. // GetHedgeOutOrderDetails 获取指定资金账号的通道交易外部委托单信息
  515. func GetHedgeOutOrderDetails(accountID int) ([]QueryHedgeOrderDetailRsp, error) {
  516. type orderDetail struct {
  517. Outorderid int64 `json:"outorderid" xorm:"'OUTORDERID'" binding:"required"` // 外部委托单ID(113+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
  518. Hedgeaccountcode string `json:"hedgeaccountcode" xorm:"'HEDGEACCOUNTCODE'" binding:"required"` // 对冲账号
  519. Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd)
  520. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 资金账号[外部母账户]
  521. Relatedorderid int64 `json:"relatedorderid" xorm:"'RELATEDORDERID'"` // 关联内部委托单号
  522. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  523. Hedgegoodsid int64 `json:"hedgegoodsid" xorm:"'HEDGEGOODSID'"` // 对冲合约ID
  524. Orderpricetype int32 `json:"orderpricetype" xorm:"'ORDERPRICETYPE'"` // 报单价格条件 - 1:市价 2: 限价
  525. Buyorsell int32 `json:"buyorsell" xorm:"'BUYORSELL'"` // 买卖方向 - 0:买 1:卖
  526. Channelbuildtype int32 `json:"channelbuildtype" xorm:"'CHANNELBUILDTYPE'"` // 开平标志- 0:无 1:建仓 2:平仓
  527. Closetype int32 `json:"closetype" xorm:"'CLOSETYPE'"` // 平仓方式 - 0:无 1:平今 2:平昨
  528. Orderprice float64 `json:"orderprice" xorm:"'ORDERPRICE'"` // 委托价格
  529. Orderqty int64 `json:"orderqty" xorm:"'ORDERQTY'"` // 委托数量
  530. Tradeqty int64 `json:"tradeqty" xorm:"'TRADEQTY'"` // 成交数量
  531. Cancelqty int64 `json:"cancelqty" xorm:"'CANCELQTY'"` // 撤销数量
  532. Validtype int32 `json:"validtype" xorm:"'VALIDTYPE'"` // 有效期类型 - 1::当日有效
  533. Hedgeflag int32 `json:"hedgeflag" xorm:"'HEDGEFLAG'"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利
  534. Channeloutorderstatus int32 `json:"channeloutorderstatus" xorm:"'CHANNELOUTORDERSTATUS'"` // 外部单据状态 - 1 - 接收报文 2 - 发送报文成功 3 - 委托成功 4 - 委托失败 5 - 全部成交 6 - 部成部撤 7 - 全部撤单
  535. Ordertime time.Time `json:"ordertime" xorm:"'ORDERTIME'"` // 委托时间
  536. Updatetime time.Time `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间
  537. Mhpinnerorderid int64 `json:"mhpinnerorderid" xorm:"'MHPINNERORDERID'"` // 接口平台委托单ID
  538. Mhprspcode int64 `json:"mhprspcode" xorm:"'MHPRSPCODE'"` // 渠道返回码
  539. Mhprsptext string `json:"mhprsptext" xorm:"'MHPRSPTEXT'"` // 渠道返回信息
  540. Optiontype int32 `json:"optiontype" xorm:"'OPTIONTYPE'"` // 期权类型 - 1:认购(看涨) 2:认沽(看跌)
  541. Premium float64 `json:"premium" xorm:"'PREMIUM'"` // 权利金
  542. Realoutorderid int64 `json:"realoutorderid" xorm:"'REALOUTORDERID'"` // 实际外部平台委托单ID
  543. Relatedcreateorderid int64 `json:"relatedcreateorderid" xorm:"'RELATEDCREATEORDERID'"` // 关联外部建仓委托单ID[平仓委托]
  544. Channeloperatetype int32 `json:"channeloperatetype" xorm:"'CHANNELOPERATETYPE'"` // 操作类型 - 1:正常委托 2:斩仓委托 3:强平委托
  545. Channelordersrc int32 `json:"channelordersrc" xorm:"'CHANNELORDERSRC'"` // 委托来源 - 1:客户端 2:风控服务 3:管理端 4:下单接口平台 5:交易服务 6:跟单服务 7:监控终端
  546. Operatorid int64 `json:"operatorid" xorm:"'OPERATORID'"` // 登录账号(LoginID)
  547. Clientordertime time.Time `json:"clientordertime" xorm:"'CLIENTORDERTIME'"` // 客户端委托时间
  548. Clientticket string `json:"clientticket" xorm:"'CLIENTTICKET'"` // 客户端流水号
  549. UUID string `json:"uuid" xorm:"'UUID'"` // 发起端唯一id
  550. Clienttype int32 `json:"clienttype" xorm:"'CLIENTTYPE'"` // 客户端类型 - 0:保留为未填终端类型 1:PC管理端 2:PC交易端 3:手机客户端_安卓 4:网页客户端 5:微信客户端 6:手机客户端_苹果 7:网上开户客户端 8:无效终端编号 9:报价终端(中江) 10;监控终端
  551. Sessionid int64 `json:"sessionid" xorm:"'SESSIONID'"` // 会话ID
  552. Orderidstr string `xorm:"ORDERIDSTR"`
  553. Goodscode string `xorm:"GOODSCODE"`
  554. Goodsname string `xorm:"GOODSNAME"`
  555. Exchangefullname string `xorm:"'EXCHANGEFULLNAME'"`
  556. }
  557. hedgeOutOrderDetails := make([]orderDetail, 0)
  558. if err := db.GetEngine().Table("HEDGE_OUTORDERDETAIL T").
  559. Select("to_char(T.OUTORDERID) ORDERIDSTR, G.GOODSCODE, G.GOODSNAME, T.*, EX.EXCHANGEFULLNAME").
  560. Join("LEFT", "GOODS G", "G.GOODSID = T.HEDGEGOODSID").
  561. Join("LEFT", "GOODSGROUP GG", "GG.GOODSGROUPID = G.GOODSGROUPID").
  562. Join("LEFT", "EXTERNALEXCHANGE EX", "GG.EXEXCHANGEID = EX.AUTOID").
  563. Where("T.ACCOUNTID = ?", accountID).Desc("T.OUTORDERID").
  564. Find(&hedgeOutOrderDetails); err != nil {
  565. return nil, err
  566. }
  567. rsp := make([]QueryHedgeOrderDetailRsp, 0)
  568. for _, v := range hedgeOutOrderDetails {
  569. // 外部单据状态 -> 委托状态
  570. // 外部单据状态 - 1 - 接收报文 2 - 发送报文成功 3 - 委托成功 4 - 委托失败 5 - 全部成交 6 - 部成部撤 7 - 全部撤单
  571. // 委托状态 - 1:委托请求 2:冻结成功 3:委托失败 4:委托部成部失败 5:委托成功 6:全部撤销 7:部成部撤 8:部成部撤部失败 9:全部成交
  572. status := v.Channeloutorderstatus
  573. if v.Channeloutorderstatus == 1 {
  574. status = 1
  575. } else if v.Channeloutorderstatus == 2 {
  576. status = 1
  577. } else if v.Channeloutorderstatus == 3 {
  578. status = 5
  579. } else if v.Channeloutorderstatus == 4 {
  580. status = 3
  581. } else if v.Channeloutorderstatus == 5 {
  582. status = 9
  583. } else if v.Channeloutorderstatus == 6 {
  584. status = 7
  585. } else if v.Channeloutorderstatus == 7 {
  586. status = 6
  587. }
  588. rsp = append(rsp, QueryHedgeOrderDetailRsp{
  589. Orderid: v.Orderidstr,
  590. Tradedate: v.Tradedate,
  591. Channelbuildtype: v.Channelbuildtype,
  592. Closetype: v.Closetype,
  593. Marketid: v.Marketid,
  594. Goodsid: int32(v.Hedgegoodsid),
  595. Accountid: v.Accountid,
  596. Buyorsell: v.Buyorsell,
  597. Pricemode: v.Orderpricetype,
  598. Orderprice: v.Orderprice,
  599. Orderqty: v.Orderqty,
  600. Tradeqty: v.Tradeqty,
  601. Openfreezemargin: 0,
  602. Channeloperatetype: v.Channeloperatetype,
  603. Ordertime: v.Ordertime,
  604. Channelinnerorderstatus: status,
  605. Curexchangerate: 1,
  606. Goodscode: v.Goodscode,
  607. Goodsname: v.Goodsname,
  608. Exchangefullname: v.Exchangefullname,
  609. })
  610. }
  611. return rsp, nil
  612. }
  613. // GetHisHedgeOutOrderDetails 获取指定资金账号的通道交易历史外部委托单信息
  614. func GetHisHedgeOutOrderDetails(accountID int, startDate, endDate string) ([]QueryHedgeOrderDetailRsp, error) {
  615. type orderDetail struct {
  616. Outorderid int64 `json:"outorderid" xorm:"'OUTORDERID'" binding:"required"` // 外部委托单ID(113+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
  617. Hedgeaccountcode string `json:"hedgeaccountcode" xorm:"'HEDGEACCOUNTCODE'" binding:"required"` // 对冲账号
  618. Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd)
  619. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 资金账号[外部母账户]
  620. Relatedorderid int64 `json:"relatedorderid" xorm:"'RELATEDORDERID'"` // 关联内部委托单号
  621. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  622. Hedgegoodsid int64 `json:"hedgegoodsid" xorm:"'HEDGEGOODSID'"` // 对冲合约ID
  623. Orderpricetype int32 `json:"orderpricetype" xorm:"'ORDERPRICETYPE'"` // 报单价格条件 - 1:市价 2: 限价
  624. Buyorsell int32 `json:"buyorsell" xorm:"'BUYORSELL'"` // 买卖方向 - 0:买 1:卖
  625. Channelbuildtype int32 `json:"channelbuildtype" xorm:"'CHANNELBUILDTYPE'"` // 开平标志- 0:无 1:建仓 2:平仓
  626. Closetype int32 `json:"closetype" xorm:"'CLOSETYPE'"` // 平仓方式 - 0:无 1:平今 2:平昨
  627. Orderprice float64 `json:"orderprice" xorm:"'ORDERPRICE'"` // 委托价格
  628. Orderqty int64 `json:"orderqty" xorm:"'ORDERQTY'"` // 委托数量
  629. Tradeqty int64 `json:"tradeqty" xorm:"'TRADEQTY'"` // 成交数量
  630. Cancelqty int64 `json:"cancelqty" xorm:"'CANCELQTY'"` // 撤销数量
  631. Validtype int32 `json:"validtype" xorm:"'VALIDTYPE'"` // 有效期类型 - 1::当日有效
  632. Hedgeflag int32 `json:"hedgeflag" xorm:"'HEDGEFLAG'"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利
  633. Channeloutorderstatus int32 `json:"channeloutorderstatus" xorm:"'CHANNELOUTORDERSTATUS'"` // 外部单据状态 - 1 - 接收报文 2 - 发送报文成功 3 - 委托成功 4 - 委托失败 5 - 全部成交 6 - 部成部撤 7 - 全部撤单
  634. Ordertime time.Time `json:"ordertime" xorm:"'ORDERTIME'"` // 委托时间
  635. Updatetime time.Time `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间
  636. Mhpinnerorderid int64 `json:"mhpinnerorderid" xorm:"'MHPINNERORDERID'"` // 接口平台委托单ID
  637. Mhprspcode int64 `json:"mhprspcode" xorm:"'MHPRSPCODE'"` // 渠道返回码
  638. Mhprsptext string `json:"mhprsptext" xorm:"'MHPRSPTEXT'"` // 渠道返回信息
  639. Optiontype int32 `json:"optiontype" xorm:"'OPTIONTYPE'"` // 期权类型 - 1:认购(看涨) 2:认沽(看跌)
  640. Premium float64 `json:"premium" xorm:"'PREMIUM'"` // 权利金
  641. Realoutorderid int64 `json:"realoutorderid" xorm:"'REALOUTORDERID'"` // 实际外部平台委托单ID
  642. Relatedcreateorderid int64 `json:"relatedcreateorderid" xorm:"'RELATEDCREATEORDERID'"` // 关联外部建仓委托单ID[平仓委托]
  643. Channeloperatetype int32 `json:"channeloperatetype" xorm:"'CHANNELOPERATETYPE'"` // 操作类型 - 1:正常委托 2:斩仓委托 3:强平委托
  644. Channelordersrc int32 `json:"channelordersrc" xorm:"'CHANNELORDERSRC'"` // 委托来源 - 1:客户端 2:风控服务 3:管理端 4:下单接口平台 5:交易服务 6:跟单服务 7:监控终端
  645. Operatorid int64 `json:"operatorid" xorm:"'OPERATORID'"` // 登录账号(LoginID)
  646. Clientordertime time.Time `json:"clientordertime" xorm:"'CLIENTORDERTIME'"` // 客户端委托时间
  647. Clientticket string `json:"clientticket" xorm:"'CLIENTTICKET'"` // 客户端流水号
  648. UUID string `json:"uuid" xorm:"'UUID'"` // 发起端唯一id
  649. Clienttype int32 `json:"clienttype" xorm:"'CLIENTTYPE'"` // 客户端类型 - 0:保留为未填终端类型 1:PC管理端 2:PC交易端 3:手机客户端_安卓 4:网页客户端 5:微信客户端 6:手机客户端_苹果 7:网上开户客户端 8:无效终端编号 9:报价终端(中江) 10;监控终端
  650. Sessionid int64 `json:"sessionid" xorm:"'SESSIONID'"` // 会话ID
  651. Orderidstr string `xorm:"ORDERIDSTR"`
  652. Goodscode string `xorm:"GOODSCODE"`
  653. Goodsname string `xorm:"GOODSNAME"`
  654. Exchangefullname string `xorm:"'EXCHANGEFULLNAME'"`
  655. }
  656. hedgeOutOrderDetails := make([]orderDetail, 0)
  657. session := db.GetEngine().Table("HIS_HEDGE_OUTORDERDETAIL T").
  658. Select("to_char(T.OUTORDERID) ORDERIDSTR, G.GOODSCODE, G.GOODSNAME, T.*, EX.EXCHANGEFULLNAME").
  659. Join("LEFT", "GOODS G", "G.GOODSID = T.HEDGEGOODSID").
  660. Join("LEFT", "GOODSGROUP GG", "GG.GOODSGROUPID = G.GOODSGROUPID").
  661. Join("LEFT", "EXTERNALEXCHANGE EX", "GG.EXEXCHANGEID = EX.AUTOID").
  662. Where("T.ISVALIDDATA = 1 and T.ACCOUNTID = ?", accountID).Desc("T.OUTORDERID")
  663. if len(startDate) > 0 {
  664. session = session.And(fmt.Sprintf("to_date(T.HISTRADEDATE,'yyyyMMdd') >= to_date('%s','yyyy-MM-dd')", startDate))
  665. }
  666. if len(endDate) > 0 {
  667. session = session.And(fmt.Sprintf("to_date(T.HISTRADEDATE,'yyyyMMdd') <= to_date('%s','yyyy-MM-dd')", endDate))
  668. }
  669. if err := session.Find(&hedgeOutOrderDetails); err != nil {
  670. return nil, err
  671. }
  672. rsp := make([]QueryHedgeOrderDetailRsp, 0)
  673. for _, v := range hedgeOutOrderDetails {
  674. // 外部单据状态 -> 委托状态
  675. // 外部单据状态 - 1 - 接收报文 2 - 发送报文成功 3 - 委托成功 4 - 委托失败 5 - 全部成交 6 - 部成部撤 7 - 全部撤单
  676. // 委托状态 - 1:委托请求 2:冻结成功 3:委托失败 4:委托部成部失败 5:委托成功 6:全部撤销 7:部成部撤 8:部成部撤部失败 9:全部成交
  677. status := v.Channeloutorderstatus
  678. if v.Channeloutorderstatus == 1 {
  679. status = 1
  680. } else if v.Channeloutorderstatus == 2 {
  681. status = 1
  682. } else if v.Channeloutorderstatus == 3 {
  683. status = 5
  684. } else if v.Channeloutorderstatus == 4 {
  685. status = 3
  686. } else if v.Channeloutorderstatus == 5 {
  687. status = 9
  688. } else if v.Channeloutorderstatus == 6 {
  689. status = 7
  690. } else if v.Channeloutorderstatus == 7 {
  691. status = 6
  692. }
  693. rsp = append(rsp, QueryHedgeOrderDetailRsp{
  694. Orderid: v.Orderidstr,
  695. Tradedate: v.Tradedate,
  696. Channelbuildtype: v.Channelbuildtype,
  697. Closetype: v.Closetype,
  698. Marketid: v.Marketid,
  699. Goodsid: int32(v.Hedgegoodsid),
  700. Accountid: v.Accountid,
  701. Buyorsell: v.Buyorsell,
  702. Pricemode: v.Orderpricetype,
  703. Orderprice: v.Orderprice,
  704. Orderqty: v.Orderqty,
  705. Tradeqty: v.Tradeqty,
  706. Openfreezemargin: 0,
  707. Channeloperatetype: v.Channeloperatetype,
  708. Ordertime: v.Ordertime,
  709. Channelinnerorderstatus: status,
  710. Curexchangerate: 1,
  711. Goodscode: v.Goodscode,
  712. Goodsname: v.Goodsname,
  713. Exchangefullname: v.Exchangefullname,
  714. })
  715. }
  716. return rsp, nil
  717. }
  718. // QueryHedgeTradeDetailRsp 获取企业风管成交单返回模型
  719. type QueryHedgeTradeDetailRsp struct {
  720. Tradeid string `json:"tradeid"` // 成交单号(108+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
  721. Buyorsell int32 `json:"buyorsell"` // 方向 - 0:买 1:卖
  722. Orderid string `json:"orderid"` // 委托单号
  723. Tradedate string `json:"tradedate"` // 交易日(yyyyMMdd)
  724. Accountid int64 `json:"accountid"` // 账号ID
  725. Goodsid int32 `json:"goodsid"` // 商品ID
  726. Marketid int32 `json:"marketid"` // 市场ID
  727. Tradetime time.Time `json:"tradetime"` // 成交时间
  728. Tradeprice float64 `json:"tradeprice"` // 成交价格
  729. Tradeqty int64 `json:"tradeqty"` // 成交数量
  730. Tradeamount float64 `json:"tradeamount"` // 成交金额(账户)
  731. Opencharge float64 `json:"opencharge"` // 建仓手续费(账户)
  732. Closecharge float64 `json:"closecharge"` // 平仓手续费(账户)
  733. Tradetype int32 `json:"tradetype"` // 成交类别 - 1:正常委托成交 2:风控斩仓成交 3:修正持仓成交 4:管理端斩仓成交
  734. Channelbuildtype int32 `json:"channelbuildtype"` // 委托单据类型 0:无 1:建仓 2:平仓
  735. Closetype int32 `json:"closetype"` // 平仓方式 - 0:无 1:平今 2:平昨
  736. Curexchangerate float64 `json:"curexchangerate"` // 当前汇率
  737. Opencharge2 float64 `json:"opencharge2"` // 建仓手续费(商品)
  738. Closecharge2 float64 `json:"closecharge2"` // 平仓手续费(商品)
  739. Goodscode string `json:"goodscode"` // 商品代码(内部)
  740. Goodsname string `json:"goodsname"` // 商品名称
  741. Exchangefullname string `json:"exchangefullname"` // 外部交易所全称
  742. }
  743. // GetHedgeInnerTradeDetails 获取通道交易内部成交单信息
  744. func GetHedgeInnerTradeDetails(accountID, goodsID, buyOrSell int) ([]QueryHedgeTradeDetailRsp, error) {
  745. type tradeDetail struct {
  746. Tradeid string `json:"tradeid" xorm:"'TRADEIDSTR'"` // 成交单号(108+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
  747. Buyorsell int32 `json:"buyorsell" xorm:"'BUYORSELL'"` // 方向 - 0:买 1:卖
  748. Orderid string `json:"orderid" xorm:"'ORDERIDSTR'"` // 委托单号
  749. Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd)
  750. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 账号ID
  751. Goodsid int32 `json:"goodsid" xorm:"'GOODSID'"` // 商品ID
  752. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  753. Tradetime time.Time `json:"tradetime" xorm:"'TRADETIME'"` // 成交时间
  754. Tradeprice float64 `json:"tradeprice" xorm:"'TRADEPRICE'"` // 成交价格
  755. Tradeqty int64 `json:"tradeqty" xorm:"'TRADEQTY'"` // 成交数量
  756. Tradeamount float64 `json:"tradeamount" xorm:"'TRADEAMOUNT'"` // 成交金额(账户)
  757. Closepl float64 `json:"closepl" xorm:"'CLOSEPL'"` // 平仓盈亏(账户)
  758. Opencharge float64 `json:"opencharge" xorm:"'OPENCHARGE'"` // 建仓手续费(账户)
  759. Closecharge float64 `json:"closecharge" xorm:"'CLOSECHARGE'"` // 平仓手续费(账户)
  760. Tradetype int32 `json:"tradetype" xorm:"'TRADETYPE'"` // 成交类别 - 1:正常委托成交 2:风控斩仓成交 3:修正持仓成交 4:管理端斩仓成交
  761. Channelbuildtype int32 `json:"channelbuildtype" xorm:"'CHANNELBUILDTYPE'"` // 委托单据类型 0:无 1:建仓 2:平仓
  762. Closetype int32 `json:"closetype" xorm:"'CLOSETYPE'"` // 平仓方式 - 0:无 1:平今 2:平昨
  763. Hedgeflag int32 `json:"hedgeflag" xorm:"'HEDGEFLAG'"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利
  764. Openqty int64 `json:"openqty" xorm:"'OPENQTY'"` // 开仓数量(先建后平操作 需要记录)
  765. Closeqty int64 `json:"closeqty" xorm:"'CLOSEQTY'"` // 平仓数量(先建后平操作 需要记录)
  766. Status int32 `json:"status" xorm:"'STATUS'"` // 处理状态 - 1:待处理 2:已处理 3:处理失败
  767. Isreckoned int32 `json:"isreckoned" xorm:"'ISRECKONED'"` // 是否结算 - 0:未结算 1:已结算
  768. Openfeealgorithm int32 `json:"openfeealgorithm" xorm:"'OPENFEEALGORITHM'"` // 建仓手续费收取方式 1:比率 2:固定
  769. Openchargevalue float64 `json:"openchargevalue" xorm:"'OPENCHARGEVALUE'"` // 建仓手续费设置值
  770. Closefeealgorithm int32 `json:"closefeealgorithm" xorm:"'CLOSEFEEALGORITHM'"` // 平仓手续费收取方式 1:比率 2:固定
  771. Closechargevalue float64 `json:"closechargevalue" xorm:"'CLOSECHARGEVALUE'"` // 平仓手续费设置值
  772. Accountcurrencyid int32 `json:"accountcurrencyid" xorm:"'ACCOUNTCURRENCYID'"` // 账户币种ID
  773. Goodscurrencyid int32 `json:"goodscurrencyid" xorm:"'GOODSCURRENCYID'"` // 商品币种ID
  774. Curexchangerate float64 `json:"curexchangerate" xorm:"'CUREXCHANGERATE'"` // 当前汇率
  775. Opencharge2 float64 `json:"opencharge2" xorm:"'OPENCHARGE2'"` // 建仓手续费(商品)
  776. Closecharge2 float64 `json:"closecharge2" xorm:"'CLOSECHARGE2'"` // 平仓手续费(商品)
  777. Closepl2 float64 `json:"closepl2" xorm:"'CLOSEPL2'"` // 平仓盈亏(商品)
  778. Closepl3 float64 `json:"closepl3" xorm:"'CLOSEPL3'"` // 平仓盈亏(账户)(逐笔)
  779. Closepl4 float64 `json:"closepl4" xorm:"'CLOSEPL4'"` // 平仓盈亏(商品)(逐笔)
  780. Extenalopenfeealgorithm int32 `json:"extenalopenfeealgorithm" xorm:"'EXTENALOPENFEEALGORITHM'"` // 建仓手续费收取方式(外部配置) 1:比率 2:固定
  781. Extenalopenchargevalue float64 `json:"extenalopenchargevalue" xorm:"'EXTENALOPENCHARGEVALUE'"` // 建仓手续费设置值
  782. Extenalclosefeealgorithm int32 `json:"extenalclosefeealgorithm" xorm:"'EXTENALCLOSEFEEALGORITHM'"` // 平仓手续费收取方式 1:比率 2:固定
  783. Extenalclosechargevalue float64 `json:"extenalclosechargevalue" xorm:"'EXTENALCLOSECHARGEVALUE'"` // 平仓手续费设置值
  784. Extenalopencharge float64 `json:"extenalopencharge" xorm:"'EXTENALOPENCHARGE'"` // 建仓手续费(商品)(外部)
  785. Extenalclosecharge float64 `json:"extenalclosecharge" xorm:"'EXTENALCLOSECHARGE'"` // 平仓手续费(商品)(外部)
  786. Parentaccountid int64 `json:"parentaccountid" xorm:"'PARENTACCOUNTID'"` // 所属母账户
  787. Relatedouttradeid int64 `json:"relatedouttradeid" xorm:"'RELATEDOUTTRADEID'"` // 关联外部成交单ID
  788. Orderidstr string `xorm:"ORDERIDSTR"`
  789. Goodscode string `xorm:"GOODSCODE"`
  790. Goodsname string `xorm:"GOODSNAME"`
  791. Exchangefullname string `xorm:"'EXCHANGEFULLNAME'"`
  792. }
  793. tradeDetails := make([]tradeDetail, 0)
  794. session := db.GetEngine().Table("HEDGE_INNERTRADEDETAIL T").
  795. Select("to_char(T.TRADEID) TRADEIDSTR, to_char(T.ORDERID) ORDERIDSTR, G.GOODSCODE, G.GOODSNAME, T.*, EX.EXCHANGEFULLNAME").
  796. Join("LEFT", "GOODS G", "G.GOODSID = T.GOODSID").
  797. Join("LEFT", "GOODSGROUP GG", "GG.GOODSGROUPID = G.GOODSGROUPID").
  798. Join("LEFT", "EXTERNALEXCHANGE EX", "GG.EXEXCHANGEID = EX.AUTOID").
  799. Where("T.ACCOUNTID = ?", accountID)
  800. if goodsID != 0 {
  801. session = session.And("T.GOODSID = ?", goodsID)
  802. }
  803. if buyOrSell != 0 {
  804. session = session.And("T.BUYORSELL = ?", buyOrSell)
  805. }
  806. if err := session.Desc("T.TRADEID").
  807. Find(&tradeDetails); err != nil {
  808. return nil, err
  809. }
  810. rsp := make([]QueryHedgeTradeDetailRsp, 0)
  811. for _, v := range tradeDetails {
  812. rsp = append(rsp, QueryHedgeTradeDetailRsp{
  813. Tradeid: v.Tradeid,
  814. Buyorsell: v.Buyorsell,
  815. Orderid: v.Orderid,
  816. Tradedate: v.Tradedate,
  817. Accountid: v.Accountid,
  818. Goodsid: v.Goodsid,
  819. Marketid: v.Marketid,
  820. Tradetime: v.Tradetime,
  821. Tradeprice: v.Tradeprice,
  822. Tradeqty: v.Tradeqty,
  823. Tradeamount: v.Tradeamount,
  824. Opencharge: v.Opencharge,
  825. Closecharge: v.Closecharge,
  826. Tradetype: v.Tradetype,
  827. Channelbuildtype: v.Channelbuildtype,
  828. Closetype: v.Closetype,
  829. Curexchangerate: v.Curexchangerate,
  830. Opencharge2: v.Opencharge2,
  831. Closecharge2: v.Closecharge2,
  832. Goodscode: v.Goodscode,
  833. Goodsname: v.Goodsname,
  834. Exchangefullname: v.Exchangefullname,
  835. })
  836. }
  837. return rsp, nil
  838. }
  839. // GetHisHedgeInnerTradeDetails 获取通道交易历史内部成交单信息
  840. func GetHisHedgeInnerTradeDetails(accountID, goodsID, buyOrSell int, startDate, endDate string) ([]QueryHedgeTradeDetailRsp, error) {
  841. type tradeDetail struct {
  842. Tradeid string `json:"tradeid" xorm:"'TRADEIDSTR'"` // 成交单号(108+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
  843. Buyorsell int32 `json:"buyorsell" xorm:"'BUYORSELL'"` // 方向 - 0:买 1:卖
  844. Orderid string `json:"orderid" xorm:"'ORDERIDSTR'"` // 委托单号
  845. Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd)
  846. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 账号ID
  847. Goodsid int32 `json:"goodsid" xorm:"'GOODSID'"` // 商品ID
  848. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  849. Tradetime time.Time `json:"tradetime" xorm:"'TRADETIME'"` // 成交时间
  850. Tradeprice float64 `json:"tradeprice" xorm:"'TRADEPRICE'"` // 成交价格
  851. Tradeqty int64 `json:"tradeqty" xorm:"'TRADEQTY'"` // 成交数量
  852. Tradeamount float64 `json:"tradeamount" xorm:"'TRADEAMOUNT'"` // 成交金额(账户)
  853. Closepl float64 `json:"closepl" xorm:"'CLOSEPL'"` // 平仓盈亏(账户)
  854. Opencharge float64 `json:"opencharge" xorm:"'OPENCHARGE'"` // 建仓手续费(账户)
  855. Closecharge float64 `json:"closecharge" xorm:"'CLOSECHARGE'"` // 平仓手续费(账户)
  856. Tradetype int32 `json:"tradetype" xorm:"'TRADETYPE'"` // 成交类别 - 1:正常委托成交 2:风控斩仓成交 3:修正持仓成交 4:管理端斩仓成交
  857. Channelbuildtype int32 `json:"channelbuildtype" xorm:"'CHANNELBUILDTYPE'"` // 委托单据类型 0:无 1:建仓 2:平仓
  858. Closetype int32 `json:"closetype" xorm:"'CLOSETYPE'"` // 平仓方式 - 0:无 1:平今 2:平昨
  859. Hedgeflag int32 `json:"hedgeflag" xorm:"'HEDGEFLAG'"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利
  860. Openqty int64 `json:"openqty" xorm:"'OPENQTY'"` // 开仓数量(先建后平操作 需要记录)
  861. Closeqty int64 `json:"closeqty" xorm:"'CLOSEQTY'"` // 平仓数量(先建后平操作 需要记录)
  862. Status int32 `json:"status" xorm:"'STATUS'"` // 处理状态 - 1:待处理 2:已处理 3:处理失败
  863. Isreckoned int32 `json:"isreckoned" xorm:"'ISRECKONED'"` // 是否结算 - 0:未结算 1:已结算
  864. Openfeealgorithm int32 `json:"openfeealgorithm" xorm:"'OPENFEEALGORITHM'"` // 建仓手续费收取方式 1:比率 2:固定
  865. Openchargevalue float64 `json:"openchargevalue" xorm:"'OPENCHARGEVALUE'"` // 建仓手续费设置值
  866. Closefeealgorithm int32 `json:"closefeealgorithm" xorm:"'CLOSEFEEALGORITHM'"` // 平仓手续费收取方式 1:比率 2:固定
  867. Closechargevalue float64 `json:"closechargevalue" xorm:"'CLOSECHARGEVALUE'"` // 平仓手续费设置值
  868. Accountcurrencyid int32 `json:"accountcurrencyid" xorm:"'ACCOUNTCURRENCYID'"` // 账户币种ID
  869. Goodscurrencyid int32 `json:"goodscurrencyid" xorm:"'GOODSCURRENCYID'"` // 商品币种ID
  870. Curexchangerate float64 `json:"curexchangerate" xorm:"'CUREXCHANGERATE'"` // 当前汇率
  871. Opencharge2 float64 `json:"opencharge2" xorm:"'OPENCHARGE2'"` // 建仓手续费(商品)
  872. Closecharge2 float64 `json:"closecharge2" xorm:"'CLOSECHARGE2'"` // 平仓手续费(商品)
  873. Closepl2 float64 `json:"closepl2" xorm:"'CLOSEPL2'"` // 平仓盈亏(商品)
  874. Closepl3 float64 `json:"closepl3" xorm:"'CLOSEPL3'"` // 平仓盈亏(账户)(逐笔)
  875. Closepl4 float64 `json:"closepl4" xorm:"'CLOSEPL4'"` // 平仓盈亏(商品)(逐笔)
  876. Extenalopenfeealgorithm int32 `json:"extenalopenfeealgorithm" xorm:"'EXTENALOPENFEEALGORITHM'"` // 建仓手续费收取方式(外部配置) 1:比率 2:固定
  877. Extenalopenchargevalue float64 `json:"extenalopenchargevalue" xorm:"'EXTENALOPENCHARGEVALUE'"` // 建仓手续费设置值
  878. Extenalclosefeealgorithm int32 `json:"extenalclosefeealgorithm" xorm:"'EXTENALCLOSEFEEALGORITHM'"` // 平仓手续费收取方式 1:比率 2:固定
  879. Extenalclosechargevalue float64 `json:"extenalclosechargevalue" xorm:"'EXTENALCLOSECHARGEVALUE'"` // 平仓手续费设置值
  880. Extenalopencharge float64 `json:"extenalopencharge" xorm:"'EXTENALOPENCHARGE'"` // 建仓手续费(商品)(外部)
  881. Extenalclosecharge float64 `json:"extenalclosecharge" xorm:"'EXTENALCLOSECHARGE'"` // 平仓手续费(商品)(外部)
  882. Parentaccountid int64 `json:"parentaccountid" xorm:"'PARENTACCOUNTID'"` // 所属母账户
  883. Relatedouttradeid int64 `json:"relatedouttradeid" xorm:"'RELATEDOUTTRADEID'"` // 关联外部成交单ID
  884. Orderidstr string `xorm:"ORDERIDSTR"`
  885. Goodscode string `xorm:"GOODSCODE"`
  886. Goodsname string `xorm:"GOODSNAME"`
  887. Exchangefullname string `xorm:"'EXCHANGEFULLNAME'"`
  888. }
  889. tradeDetails := make([]tradeDetail, 0)
  890. session := db.GetEngine().Table("HIS_HEDGE_INNERTRADEDETAIL T").
  891. Select("to_char(T.TRADEID) TRADEIDSTR, to_char(T.ORDERID) ORDERIDSTR, G.GOODSCODE, G.GOODSNAME, T.*, EX.EXCHANGEFULLNAME").
  892. Join("LEFT", "GOODS G", "G.GOODSID = T.GOODSID").
  893. Join("LEFT", "GOODSGROUP GG", "GG.GOODSGROUPID = G.GOODSGROUPID").
  894. Join("LEFT", "EXTERNALEXCHANGE EX", "GG.EXEXCHANGEID = EX.AUTOID").
  895. Where("T.ISVALIDDATA = 1 and T.ACCOUNTID = ?", accountID)
  896. if goodsID != 0 {
  897. session = session.And("T.GOODSID = ?", goodsID)
  898. }
  899. if buyOrSell != 0 {
  900. session = session.And("T.BUYORSELL = ?", buyOrSell)
  901. }
  902. if len(startDate) > 0 {
  903. session = session.And(fmt.Sprintf("to_date(T.HISTRADEDATE,'yyyyMMdd') >= to_date('%s','yyyy-MM-dd')", startDate))
  904. }
  905. if len(endDate) > 0 {
  906. session = session.And(fmt.Sprintf("to_date(T.HISTRADEDATE,'yyyyMMdd') <= to_date('%s','yyyy-MM-dd')", endDate))
  907. }
  908. if err := session.Desc("T.TRADEID").
  909. Find(&tradeDetails); err != nil {
  910. return nil, err
  911. }
  912. rsp := make([]QueryHedgeTradeDetailRsp, 0)
  913. for _, v := range tradeDetails {
  914. rsp = append(rsp, QueryHedgeTradeDetailRsp{
  915. Tradeid: v.Tradeid,
  916. Buyorsell: v.Buyorsell,
  917. Orderid: v.Orderid,
  918. Tradedate: v.Tradedate,
  919. Accountid: v.Accountid,
  920. Goodsid: v.Goodsid,
  921. Marketid: v.Marketid,
  922. Tradetime: v.Tradetime,
  923. Tradeprice: v.Tradeprice,
  924. Tradeqty: v.Tradeqty,
  925. Tradeamount: v.Tradeamount,
  926. Opencharge: v.Opencharge,
  927. Closecharge: v.Closecharge,
  928. Tradetype: v.Tradetype,
  929. Channelbuildtype: v.Channelbuildtype,
  930. Closetype: v.Closetype,
  931. Curexchangerate: v.Curexchangerate,
  932. Opencharge2: v.Opencharge2,
  933. Closecharge2: v.Closecharge2,
  934. Goodscode: v.Goodscode,
  935. Goodsname: v.Goodsname,
  936. Exchangefullname: v.Exchangefullname,
  937. })
  938. }
  939. return rsp, nil
  940. }
  941. // GetHedgeOutTradeDetails 获取通道交易外部成交单信息
  942. func GetHedgeOutTradeDetails(accountID, goodsID, buyOrSell int) ([]QueryHedgeTradeDetailRsp, error) {
  943. type tradeDetail struct {
  944. Outtradeid string `json:"outtradeid" xorm:"'OUTTRADEIDSTR'" binding:"required"` // 外部成交单ID(114+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
  945. Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd)
  946. Relatedoutorderid string `json:"relatedoutorderid" xorm:"'RELATEDOUTORDERIDSTR'"` // 关联外部委托单ID
  947. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 资金账号[外部母账户]
  948. Hedgeaccountcode string `json:"hedgeaccountcode" xorm:"'HEDGEACCOUNTCODE'"` // 对冲账号
  949. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  950. Hedgegoodsid int64 `json:"hedgegoodsid" xorm:"'HEDGEGOODSID'"` // 对冲合约ID
  951. Buyorsell int32 `json:"buyorsell" xorm:"'BUYORSELL'"` // 买卖方向 - 0:买 1:卖
  952. Channelbuildtype int32 `json:"channelbuildtype" xorm:"'CHANNELBUILDTYPE'"` // 开平标志- 0:无 1:建仓 2:平仓
  953. Closetype int32 `json:"closetype" xorm:"'CLOSETYPE'"` // 平仓方式 - 0:无 1:平今 2:平昨
  954. Hedgeflag int32 `json:"hedgeflag" xorm:"'HEDGEFLAG'"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利
  955. Tradeprice float64 `json:"tradeprice" xorm:"'TRADEPRICE'"` // 成交价格
  956. Tradeqty int64 `json:"tradeqty" xorm:"'TRADEQTY'"` // 成交数量
  957. Tradetime time.Time `json:"tradetime" xorm:"'TRADETIME'"` // 成交时间
  958. Relatedmhpinnerorderid int64 `json:"relatedmhpinnerorderid" xorm:"'RELATEDMHPINNERORDERID'"` // 接口平台委托单ID
  959. Mhpinnertradeid int64 `json:"mhpinnertradeid" xorm:"'MHPINNERTRADEID'"` // 接口平台成交单ID
  960. Hasinnerorder int32 `json:"hasinnerorder" xorm:"'HASINNERORDER'"` // 是否有内部单关联 - 0:无 1:有
  961. Isvalid int32 `json:"isvalid" xorm:"'ISVALID'"` // 是否有效 - 0:无效 1:有效
  962. Optiontype int32 `json:"optiontype" xorm:"'OPTIONTYPE'"` // 期权类型 - 1:认购(看涨) 2:认沽(看跌)
  963. Premium float64 `json:"premium" xorm:"'PREMIUM'"` // 权利金
  964. Tradetype int32 `json:"tradetype" xorm:"'TRADETYPE'"` // 成交类别 - 1:正常委托成交3:修正持仓成交
  965. Orderidstr string `xorm:"ORDERIDSTR"`
  966. Goodscode string `xorm:"GOODSCODE"`
  967. Goodsname string `xorm:"GOODSNAME"`
  968. Exchangefullname string `xorm:"'EXCHANGEFULLNAME'"`
  969. Tradeamount float64 `xorm:"TRADEAMOUNT"` // 成交金额
  970. }
  971. tradeDetails := make([]tradeDetail, 0)
  972. session := db.GetEngine().Table("HEDGE_OUTTRADEDETAIL T").
  973. Select("to_char(T.OUTTRADEID) OUTTRADEIDSTR, to_char(T.RELATEDOUTORDERID) RELATEDOUTORDERIDSTR, G.GOODSCODE, G.GOODSNAME, T.*, EX.EXCHANGEFULLNAME, (T.TRADEPRICE * T.TRADEQTY * G.AGREEUNIT) TRADEAMOUNT").
  974. Join("LEFT", "GOODS G", "G.GOODSID = T.HEDGEGOODSID").
  975. Join("LEFT", "GOODSGROUP GG", "GG.GOODSGROUPID = G.GOODSGROUPID").
  976. Join("LEFT", "EXTERNALEXCHANGE EX", "GG.EXEXCHANGEID = EX.AUTOID").
  977. Where("T.ACCOUNTID = ?", accountID)
  978. if goodsID != 0 {
  979. session = session.And("T.HEDGEGOODSID = ?", goodsID)
  980. }
  981. if buyOrSell != 0 {
  982. session = session.And("T.BUYORSELL = ?", buyOrSell)
  983. }
  984. if err := session.Desc("T.OUTTRADEID").
  985. Find(&tradeDetails); err != nil {
  986. return nil, err
  987. }
  988. rsp := make([]QueryHedgeTradeDetailRsp, 0)
  989. for _, v := range tradeDetails {
  990. rsp = append(rsp, QueryHedgeTradeDetailRsp{
  991. Tradeid: v.Outtradeid,
  992. Buyorsell: v.Buyorsell,
  993. Orderid: v.Relatedoutorderid,
  994. Tradedate: v.Tradedate,
  995. Accountid: v.Accountid,
  996. Goodsid: int32(v.Hedgegoodsid),
  997. Marketid: v.Marketid,
  998. Tradetime: v.Tradetime,
  999. Tradeprice: v.Tradeprice,
  1000. Tradeqty: v.Tradeqty,
  1001. Tradeamount: v.Tradeamount,
  1002. Opencharge: 0,
  1003. Closecharge: 0,
  1004. Tradetype: v.Tradetype,
  1005. Channelbuildtype: v.Channelbuildtype,
  1006. Closetype: v.Closetype,
  1007. Curexchangerate: 1,
  1008. Opencharge2: 0,
  1009. Closecharge2: 0,
  1010. Goodscode: v.Goodscode,
  1011. Goodsname: v.Goodsname,
  1012. Exchangefullname: v.Exchangefullname,
  1013. })
  1014. }
  1015. return rsp, nil
  1016. }
  1017. // GetHisHedgeOutTradeDetails 获取通道交易外部历史成交单信息
  1018. func GetHisHedgeOutTradeDetails(accountID, goodsID, buyOrSell int, startDate, endDate string) ([]QueryHedgeTradeDetailRsp, error) {
  1019. type tradeDetail struct {
  1020. Outtradeid string `json:"outtradeid" xorm:"'OUTTRADEIDSTR'" binding:"required"` // 外部成交单ID(114+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
  1021. Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd)
  1022. Relatedoutorderid string `json:"relatedoutorderid" xorm:"'RELATEDOUTORDERIDSTR'"` // 关联外部委托单ID
  1023. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 资金账号[外部母账户]
  1024. Hedgeaccountcode string `json:"hedgeaccountcode" xorm:"'HEDGEACCOUNTCODE'"` // 对冲账号
  1025. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  1026. Hedgegoodsid int64 `json:"hedgegoodsid" xorm:"'HEDGEGOODSID'"` // 对冲合约ID
  1027. Buyorsell int32 `json:"buyorsell" xorm:"'BUYORSELL'"` // 买卖方向 - 0:买 1:卖
  1028. Channelbuildtype int32 `json:"channelbuildtype" xorm:"'CHANNELBUILDTYPE'"` // 开平标志- 0:无 1:建仓 2:平仓
  1029. Closetype int32 `json:"closetype" xorm:"'CLOSETYPE'"` // 平仓方式 - 0:无 1:平今 2:平昨
  1030. Hedgeflag int32 `json:"hedgeflag" xorm:"'HEDGEFLAG'"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利
  1031. Tradeprice float64 `json:"tradeprice" xorm:"'TRADEPRICE'"` // 成交价格
  1032. Tradeqty int64 `json:"tradeqty" xorm:"'TRADEQTY'"` // 成交数量
  1033. Tradetime time.Time `json:"tradetime" xorm:"'TRADETIME'"` // 成交时间
  1034. Relatedmhpinnerorderid int64 `json:"relatedmhpinnerorderid" xorm:"'RELATEDMHPINNERORDERID'"` // 接口平台委托单ID
  1035. Mhpinnertradeid int64 `json:"mhpinnertradeid" xorm:"'MHPINNERTRADEID'"` // 接口平台成交单ID
  1036. Hasinnerorder int32 `json:"hasinnerorder" xorm:"'HASINNERORDER'"` // 是否有内部单关联 - 0:无 1:有
  1037. Isvalid int32 `json:"isvalid" xorm:"'ISVALID'"` // 是否有效 - 0:无效 1:有效
  1038. Optiontype int32 `json:"optiontype" xorm:"'OPTIONTYPE'"` // 期权类型 - 1:认购(看涨) 2:认沽(看跌)
  1039. Premium float64 `json:"premium" xorm:"'PREMIUM'"` // 权利金
  1040. Tradetype int32 `json:"tradetype" xorm:"'TRADETYPE'"` // 成交类别 - 1:正常委托成交3:修正持仓成交
  1041. Orderidstr string `xorm:"ORDERIDSTR"`
  1042. Goodscode string `xorm:"GOODSCODE"`
  1043. Goodsname string `xorm:"GOODSNAME"`
  1044. Exchangefullname string `xorm:"'EXCHANGEFULLNAME'"`
  1045. Tradeamount float64 `xorm:"TRADEAMOUNT"` // 成交金额
  1046. }
  1047. tradeDetails := make([]tradeDetail, 0)
  1048. session := db.GetEngine().Table("HIS_HEDGE_OUTTRADEDETAIL T").
  1049. Select("to_char(T.OUTTRADEID) OUTTRADEIDSTR, to_char(T.RELATEDOUTORDERID) RELATEDOUTORDERIDSTR, G.GOODSCODE, G.GOODSNAME, T.*, EX.EXCHANGEFULLNAME, (T.TRADEPRICE * T.TRADEQTY * G.AGREEUNIT) TRADEAMOUNT").
  1050. Join("LEFT", "GOODS G", "G.GOODSID = T.HEDGEGOODSID").
  1051. Join("LEFT", "GOODSGROUP GG", "GG.GOODSGROUPID = G.GOODSGROUPID").
  1052. Join("LEFT", "EXTERNALEXCHANGE EX", "GG.EXEXCHANGEID = EX.AUTOID").
  1053. Where("T.ACCOUNTID = ?", accountID)
  1054. if goodsID != 0 {
  1055. session = session.And("T.HEDGEGOODSID = ?", goodsID)
  1056. }
  1057. if buyOrSell != 0 {
  1058. session = session.And("T.BUYORSELL = ?", buyOrSell)
  1059. }
  1060. if len(startDate) > 0 {
  1061. session = session.And(fmt.Sprintf("to_date(T.HISTRADEDATE,'yyyyMMdd') >= to_date('%s','yyyy-MM-dd')", startDate))
  1062. }
  1063. if len(endDate) > 0 {
  1064. session = session.And(fmt.Sprintf("to_date(T.HISTRADEDATE,'yyyyMMdd') <= to_date('%s','yyyy-MM-dd')", endDate))
  1065. }
  1066. if err := session.Desc("T.OUTTRADEID").
  1067. Find(&tradeDetails); err != nil {
  1068. return nil, err
  1069. }
  1070. rsp := make([]QueryHedgeTradeDetailRsp, 0)
  1071. for _, v := range tradeDetails {
  1072. rsp = append(rsp, QueryHedgeTradeDetailRsp{
  1073. Tradeid: v.Outtradeid,
  1074. Buyorsell: v.Buyorsell,
  1075. Orderid: v.Relatedoutorderid,
  1076. Tradedate: v.Tradedate,
  1077. Accountid: v.Accountid,
  1078. Goodsid: int32(v.Hedgegoodsid),
  1079. Marketid: v.Marketid,
  1080. Tradetime: v.Tradetime,
  1081. Tradeprice: v.Tradeprice,
  1082. Tradeqty: v.Tradeqty,
  1083. Tradeamount: v.Tradeamount,
  1084. Opencharge: 0,
  1085. Closecharge: 0,
  1086. Tradetype: v.Tradetype,
  1087. Channelbuildtype: v.Channelbuildtype,
  1088. Closetype: v.Closetype,
  1089. Curexchangerate: 1,
  1090. Opencharge2: 0,
  1091. Closecharge2: 0,
  1092. Goodscode: v.Goodscode,
  1093. Goodsname: v.Goodsname,
  1094. Exchangefullname: v.Exchangefullname,
  1095. })
  1096. }
  1097. return rsp, nil
  1098. }