ermcp8.go 85 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350
  1. package models
  2. import (
  3. "fmt"
  4. "mtp2_if/db"
  5. "mtp2_if/logger"
  6. "mtp2_if/utils"
  7. "time"
  8. )
  9. // Ermcp2himiddlegoodsOrc 项目套保品种明细
  10. type Ermcp2himiddlegoodsOrc struct {
  11. HEDGEDITEMID int64 `json:"hedgeditemid" xorm:"HEDGEDITEMID"` // 被套期项目ID(624+Unix秒时间戳(10位)+xxxxxx)
  12. MIDDLEGOODSID int64 `json:"middlegoodsid" xorm:"MIDDLEGOODSID"` // 套保品种ID
  13. DELIVERYGOODSID int64 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID
  14. WRSTANDARDID int64 `json:"wrstandardid" xorm:"WRSTANDARDID"` // 现货商品ID
  15. VATRATE float64 `json:"vatrate" xorm:"VATRATE"` // 增值税
  16. SPOTCONVERTRATIO float64 `json:"spotconvertratio" xorm:"SPOTCONVERTRATIO"` // 折算系数 [现货]
  17. UNEXESPOTQTY float64 `json:"unexespotqty" xorm:"UNEXESPOTQTY"` // 未执行现货量
  18. UNEXEHEDGEQTY float64 `json:"unexehedgeqty" xorm:"UNEXEHEDGEQTY"` // 未执行套期量 = 未执行现货量*折算系数* (1/(1+增值税)) * 套期比例(项目上)
  19. FUTUREHEDGEQTY float64 `json:"futurehedgeqty" xorm:"FUTUREHEDGEQTY"` // 期货持仓套期量
  20. HIEXPSOURE float64 `json:"hiexpsoure" xorm:"HIEXPSOURE"` // 期现敞口量 = 未执行套期量 + 期货持仓套期量
  21. TRADEUSERID int64 `json:"tradeuserid" xorm:"TRADEUSERID"` // 交易用户ID
  22. AREAUSERID int64 `json:"areauserid" xorm:"AREAUSERID"` // 企业ID
  23. CREATETIME time.Time `json:"createtime" xorm:"CREATETIME"` // 创建时间
  24. UPDATETIME time.Time `json:"updatetime" xorm:"UPDATETIME"` // 更新时间
  25. }
  26. // TableName is ERMCP2_HIMIDDLEGOODS
  27. func (r *Ermcp2himiddlegoodsOrc) TableName() string {
  28. return "ERMCP2_HIMIDDLEGOODS"
  29. }
  30. // Ermcp2hedgeditem 被套期项目表
  31. type Ermcp2hedgeditemOrc struct {
  32. HEDGEDITEMID int64 `json:"hedgeditemid" xorm:"HEDGEDITEMID"` // 被套期项目ID(624+Unix秒时间戳(10位)+xxxxxx)
  33. HEDGEDITEMNUM string `json:"hedgeditemnum" xorm:"HEDGEDITEMNUM"` // 项目编号
  34. HEDGEDITEMNAME string `json:"hedgeditemname" xorm:"HEDGEDITEMNAME"` // 项目名称
  35. HEDGEDTYPE int32 `json:"hedgedtype" xorm:"HEDGEDTYPE"` // 套期类型 - 1:采购计划项目 2:销售计划项目 3:现货贸易项目 4:库存存货项目 5:定价采购合同项目
  36. PLANSTARTDATE time.Time `json:"planstartdate" xorm:"PLANSTARTDATE"` // 计划开始日期
  37. PLANENDDATE time.Time `json:"planenddate" xorm:"PLANENDDATE"` // 计划结束日期
  38. HEDGERATE float64 `json:"hedgerate" xorm:"HEDGERATE"` // 套期比率
  39. TRADEUSERID int64 `json:"tradeuserid" xorm:"TRADEUSERID"` // 交易用户ID
  40. AREAUSERID int64 `json:"areauserid" xorm:"AREAUSERID"` // 企业ID
  41. HEDGEDITEMSTATUS int32 `json:"hedgeditemstatus" xorm:"HEDGEDITEMSTATUS"` // 项目状态 - 0:未提交 1:待审核 2:执行中 3:正常完结 4:审核拒绝 5:异常完结 6:已撤回
  42. APPLYSRC int32 `json:"applysrc" xorm:"APPLYSRC"` // 申请来源 - 1:管理端 2:终端
  43. APPLYID int64 `json:"applyid" xorm:"APPLYID"` // 申请人
  44. REMARK string `json:"remark" xorm:"REMARK"` // 备注
  45. CREATETIME time.Time `json:"createtime" xorm:"CREATETIME"` // 申请时间
  46. AUDITTRADEDATE string `json:"audittradedate" xorm:"AUDITTRADEDATE"` // 审核交易日(yyyyMMdd)
  47. AUDITID int64 `json:"auditid" xorm:"AUDITID"` // 审核人
  48. AUDITSRC int32 `json:"auditsrc" xorm:"AUDITSRC"` // 审核来源 - 1:管理端 2:终端
  49. AUDITTIME time.Time `json:"audittime" xorm:"AUDITTIME"` // 审核时间
  50. AUDITREMARK string `json:"auditremark" xorm:"AUDITREMARK"` // 审核备注
  51. DELIVERYGOODSID int64 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID
  52. WRSTANDARDID int64 `json:"wrstandardid" xorm:"WRSTANDARDID"` // 现货商品ID
  53. VATRATE float64 `json:"vatrate" xorm:"VATRATE"` // 增值税
  54. HEDGEQTY float64 `json:"hedgeqty" xorm:"HEDGEQTY"` // 套期现货量
  55. HEDGEAMOUNT float64 `json:"hedgeamount" xorm:"HEDGEAMOUNT"` // 套期市价总额
  56. HEDGERESTAMOUNT float64 `json:"hedgerestamount" xorm:"HEDGERESTAMOUNT"` // 套期剩余市价总额【现货贸易】
  57. HEDGECONTRACTAMOUNT float64 `json:"hedgecontractamount" xorm:"HEDGECONTRACTAMOUNT"` // 套期定价总额 【定价采购合同】【现货贸易】
  58. ORIAVGPRICE float64 `json:"oriavgprice" xorm:"ORIAVGPRICE"` // 期初市场均价 = 套期市价总额 / 套期现货量
  59. EXEQTY float64 `json:"exeqty" xorm:"EXEQTY"` // 执行现货量
  60. EXEAMOUNT float64 `json:"exeamount" xorm:"EXEAMOUNT"` // 执行市价总额
  61. EXERESTAMOUNT float64 `json:"exerestamount" xorm:"EXERESTAMOUNT"` // 执行剩余市价总额【现货贸易】
  62. EXEAVGPRICE float64 `json:"exeavgprice" xorm:"EXEAVGPRICE"` // 执行市场均价= 执行市价总额 / 执行现货量
  63. EXECONTRACTAMOUNT float64 `json:"execontractamount" xorm:"EXECONTRACTAMOUNT"` // 执行定价总额
  64. CURPRICE float64 `json:"curprice" xorm:"CURPRICE"` // 当前市场价
  65. UNEXEQTY float64 `json:"unexeqty" xorm:"UNEXEQTY"` // 未执行现货量 = 套期现货量 - 执行现货量
  66. SPOTHEDGEPL float64 `json:"spothedgepl" xorm:"SPOTHEDGEPL"` // 现货套期损益 =(执行市场均价-期初市场均价)*执行现货量 * 方向(销售计划 为 -1, 其它为1)
  67. SPOTPL float64 `json:"spotpl" xorm:"SPOTPL"` // 现货套期损益 = 现货实际损益 + 现货浮动损益
  68. FUTUREHEDGEPL float64 `json:"futurehedgepl" xorm:"FUTUREHEDGEPL"` // 期货实际损益
  69. FUTUREPL float64 `json:"futurepl" xorm:"FUTUREPL"` // 期货套期损益
  70. HEDGESUMPL float64 `json:"hedgesumpl" xorm:"HEDGESUMPL"` // 套期汇总损益 = 期货汇总损益 + 现货汇总损益
  71. SPOTTRADEPL float64 `json:"spottradepl" xorm:"SPOTTRADEPL"` // 现货贸易损益【现货贸易】= 执行合同定价总额 - 套期合同定价总额
  72. VATPL float64 `json:"vatpl" xorm:"VATPL"` // 增值税损益【现货贸易】= 现货贸易损益 * (增值税率 /(1+增值税率))
  73. SUMOBSPL float64 `json:"sumobspl" xorm:"SUMOBSPL"` // 汇总绝对损益【现货贸易】=现货贸易损益+增值税损益+期货套期损益
  74. SPOTBOOKAMOUNT float64 `json:"spotbookamount" xorm:"SPOTBOOKAMOUNT"` // 现货账面总额
  75. CURSTOCK float64 `json:"curstock" xorm:"CURSTOCK"` // 期末库存量 = 采购总量 - 销售总量
  76. ENDDATE time.Time `json:"enddate" xorm:"ENDDATE"` // 完成日期
  77. ENDTRADEDATE string `json:"endtradedate" xorm:"ENDTRADEDATE"` // 完成交易日
  78. UPDATETIME time.Time `json:"updatetime" xorm:"UPDATETIME"` // 更新时间
  79. ORISPOTHEDGEPL float64 `json:"orispothedgepl" xorm:"ORISPOTHEDGEPL"` // 期初现货实际损益
  80. ORIFUTUREHEDGEPL float64 `json:"orifuturehedgepl" xorm:"ORIFUTUREHEDGEPL"` // 期初期货实际损益
  81. ORISPOTPL float64 `json:"orispotpl" xorm:"ORISPOTPL"` // 期初现货套期损益
  82. ORIFUTUREPL float64 `json:"orifuturepl" xorm:"ORIFUTUREPL"` // 期初期货套期损益
  83. SPOTFLOATPL float64 `json:"spotfloatpl" xorm:"SPOTFLOATPL"` // 现货浮动损益 =(当前市场价 - 期初市场价)*未执行现货量 * 方向(销售计划 为 -1, 其它为1)
  84. FUTUREFLOATPL float64 `json:"futurefloatpl" xorm:"FUTUREFLOATPL"` // 期货浮动损益
  85. }
  86. // TableName is ERMCP2_HEDGEDITEM
  87. func (r *Ermcp2hedgeditemOrc) TableName() string {
  88. return "ERMCP2_HEDGEDITEM"
  89. }
  90. // Reckonermcp2hedgeditem 被套期项目日照表
  91. type Reckonermcp2hedgeditem struct {
  92. RECKONDATE string `json:"reckondate" xorm:"RECKONDATE"` // 日照时期(yyyyMMdd)
  93. HEDGEDITEMID int64 `json:"hedgeditemid" xorm:"HEDGEDITEMID"` // 被套期项目ID(624+Unix秒时间戳(10位)+xxxxxx)
  94. HEDGEDITEMNUM string `json:"hedgeditemnum" xorm:"HEDGEDITEMNUM"` // 项目编号
  95. HEDGEDITEMNAME string `json:"hedgeditemname" xorm:"HEDGEDITEMNAME"` // 项目名称
  96. HEDGEDTYPE int32 `json:"hedgedtype" xorm:"HEDGEDTYPE"` // 套期类型 - 1:采购计划项目 2:销售计划项目 3:现货贸易项目 4:库存存货项目 5:定价采购合同项目
  97. PLANSTARTDATE time.Time `json:"planstartdate" xorm:"PLANSTARTDATE"` // 计划开始日期
  98. PLANENDDATE time.Time `json:"planenddate" xorm:"PLANENDDATE"` // 计划结束日期
  99. HEDGERATE float64 `json:"hedgerate" xorm:"HEDGERATE"` // 套期比率
  100. TRADEUSERID int64 `json:"tradeuserid" xorm:"TRADEUSERID"` // 交易用户ID
  101. AREAUSERID int64 `json:"areauserid" xorm:"AREAUSERID"` // 企业ID
  102. HEDGEDITEMSTATUS int32 `json:"hedgeditemstatus" xorm:"HEDGEDITEMSTATUS"` // 项目状态 - 0:未提交 1:待审核 2:执行中 3:正常完结 4:审核拒绝 5:异常完结 6:已撤回
  103. APPLYSRC int32 `json:"applysrc" xorm:"APPLYSRC"` // 申请来源 - 1:管理端 2:终端
  104. APPLYID int64 `json:"applyid" xorm:"APPLYID"` // 申请人
  105. REMARK string `json:"remark" xorm:"REMARK"` // 备注
  106. CREATETIME time.Time `json:"createtime" xorm:"CREATETIME"` // 申请时间
  107. AUDITTRADEDATE string `json:"audittradedate" xorm:"AUDITTRADEDATE"` // 审核交易日(yyyyMMdd)
  108. AUDITID int64 `json:"auditid" xorm:"AUDITID"` // 审核人
  109. AUDITSRC int32 `json:"auditsrc" xorm:"AUDITSRC"` // 审核来源 - 1:管理端 2:终端
  110. AUDITTIME time.Time `json:"audittime" xorm:"AUDITTIME"` // 审核时间
  111. AUDITREMARK string `json:"auditremark" xorm:"AUDITREMARK"` // 审核备注
  112. DELIVERYGOODSID int64 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID
  113. WRSTANDARDID int64 `json:"wrstandardid" xorm:"WRSTANDARDID"` // 现货商品ID
  114. VATRATE float64 `json:"vatrate" xorm:"VATRATE"` // 增值税
  115. HEDGEQTY float64 `json:"hedgeqty" xorm:"HEDGEQTY"` // 套期现货量
  116. HEDGEAMOUNT float64 `json:"hedgeamount" xorm:"HEDGEAMOUNT"` // 套期市价总额
  117. HEDGERESTAMOUNT float64 `json:"hedgerestamount" xorm:"HEDGERESTAMOUNT"` // 套期剩余市价总额【现货贸易】
  118. HEDGECONTRACTAMOUNT float64 `json:"hedgecontractamount" xorm:"HEDGECONTRACTAMOUNT"` // 套期定价总额 【定价采购合同】【现货贸易】
  119. ORIAVGPRICE float64 `json:"oriavgprice" xorm:"ORIAVGPRICE"` // 期初市场均价 = 套期市价总额 / 套期现货量
  120. EXEQTY float64 `json:"exeqty" xorm:"EXEQTY"` // 执行现货量
  121. EXEAMOUNT float64 `json:"exeamount" xorm:"EXEAMOUNT"` // 执行市价总额
  122. EXERESTAMOUNT float64 `json:"exerestamount" xorm:"EXERESTAMOUNT"` // 执行剩余市价总额【现货贸易】
  123. EXEAVGPRICE float64 `json:"exeavgprice" xorm:"EXEAVGPRICE"` // 执行市场均价= 执行市价总额 / 执行现货量
  124. EXECONTRACTAMOUNT float64 `json:"execontractamount" xorm:"EXECONTRACTAMOUNT"` // 执行定价总额
  125. CURPRICE float64 `json:"curprice" xorm:"CURPRICE"` // 当前市场价
  126. UNEXEQTY float64 `json:"unexeqty" xorm:"UNEXEQTY"` // 未执行现货量 = 套期现货量 - 执行现货量
  127. SPOTHEDGEPL float64 `json:"spothedgepl" xorm:"SPOTHEDGEPL"` // 现货套期损益 =(执行市场均价-期初市场均价)*执行现货量 * 方向(销售计划 为 -1, 其它为1)
  128. SPOTPL float64 `json:"spotpl" xorm:"SPOTPL"` // 现货套期损益 = 现货实际损益 + 现货浮动损益
  129. FUTUREHEDGEPL float64 `json:"futurehedgepl" xorm:"FUTUREHEDGEPL"` // 期货实际损益
  130. FUTUREPL float64 `json:"futurepl" xorm:"FUTUREPL"` // 期货套期损益
  131. HEDGESUMPL float64 `json:"hedgesumpl" xorm:"HEDGESUMPL"` // 套期汇总损益 = 期货汇总损益 + 现货汇总损益
  132. SPOTTRADEPL float64 `json:"spottradepl" xorm:"SPOTTRADEPL"` // 现货贸易损益【现货贸易】= 执行合同定价总额 - 套期合同定价总额
  133. VATPL float64 `json:"vatpl" xorm:"VATPL"` // 增值税损益【现货贸易】= 现货贸易损益 * (增值税率 /(1+增值税率))
  134. SUMOBSPL float64 `json:"sumobspl" xorm:"SUMOBSPL"` // 汇总绝对损益【现货贸易】=现货贸易损益+增值税损益+期货套期损益
  135. SPOTBOOKAMOUNT float64 `json:"spotbookamount" xorm:"SPOTBOOKAMOUNT"` // 现货账面总额
  136. CURSTOCK float64 `json:"curstock" xorm:"CURSTOCK"` // 期末库存量 = 采购总量 - 销售总量
  137. ENDDATE time.Time `json:"enddate" xorm:"ENDDATE"` // 完成日期
  138. ENDTRADEDATE string `json:"endtradedate" xorm:"ENDTRADEDATE"` // 完成交易日
  139. UPDATETIME time.Time `json:"updatetime" xorm:"UPDATETIME"` // 更新时间
  140. ORISPOTHEDGEPL float64 `json:"orispothedgepl" xorm:"ORISPOTHEDGEPL"` // 期初现货实际损益
  141. ORIFUTUREHEDGEPL float64 `json:"orifuturehedgepl" xorm:"ORIFUTUREHEDGEPL"` // 期初期货实际损益
  142. ORISPOTPL float64 `json:"orispotpl" xorm:"ORISPOTPL"` // 期初现货套期损益
  143. ORIFUTUREPL float64 `json:"orifuturepl" xorm:"ORIFUTUREPL"` // 期初期货套期损益
  144. SPOTFLOATPL float64 `json:"spotfloatpl" xorm:"SPOTFLOATPL"` // 现货浮动损益 =(当前市场价 - 期初市场价)*未执行现货量 * 方向(销售计划 为 -1, 其它为1)
  145. FUTUREFLOATPL float64 `json:"futurefloatpl" xorm:"FUTUREFLOATPL"` // 期货浮动损益
  146. }
  147. // TableName is RECKON_ERMCP2_HEDGEDITEM
  148. func (r *Reckonermcp2hedgeditem) TableName() string {
  149. return "RECKON_ERMCP2_HEDGEDITEM"
  150. }
  151. // Reportermcp2hedgeditem 被套期项目报表表
  152. type Reportermcp2hedgeditem struct {
  153. CYCLETIME string `json:"cycletime" xorm:"CYCLETIME"` // 周期时间 月(YYYYMM) 季(YYYYQ) 年(YYYY) 周(YYYYIW) 全(0)【原值】
  154. CYCLETYPE int32 `json:"cycletype" xorm:"CYCLETYPE"` // 周期类型 - 1:月 2:季 3:年 4:周 5:全报表【原值】
  155. HEDGEDITEMID int64 `json:"hedgeditemid" xorm:"HEDGEDITEMID"` // 被套期项目ID(624+Unix秒时间戳(10位)+xxxxxx)
  156. HEDGEDITEMNUM string `json:"hedgeditemnum" xorm:"HEDGEDITEMNUM"` // 项目编号
  157. HEDGEDITEMNAME string `json:"hedgeditemname" xorm:"HEDGEDITEMNAME"` // 项目名称
  158. HEDGEDTYPE int32 `json:"hedgedtype" xorm:"HEDGEDTYPE"` // 套期类型 - 1:采购计划项目 2:销售计划项目 3:现货贸易项目 4:库存存货项目 5:定价采购合同项目
  159. PLANSTARTDATE time.Time `json:"planstartdate" xorm:"PLANSTARTDATE"` // 计划开始日期
  160. PLANENDDATE time.Time `json:"planenddate" xorm:"PLANENDDATE"` // 计划结束日期
  161. HEDGERATE float64 `json:"hedgerate" xorm:"HEDGERATE"` // 套期比率
  162. TRADEUSERID int64 `json:"tradeuserid" xorm:"TRADEUSERID"` // 交易用户ID
  163. AREAUSERID int64 `json:"areauserid" xorm:"AREAUSERID"` // 企业ID
  164. HEDGEDITEMSTATUS int32 `json:"hedgeditemstatus" xorm:"HEDGEDITEMSTATUS"` // 项目状态 - 0:未提交 1:待审核 2:执行中 3:正常完结 4:审核拒绝 5:异常完结 6:已撤回
  165. APPLYSRC int32 `json:"applysrc" xorm:"APPLYSRC"` // 申请来源 - 1:管理端 2:终端
  166. APPLYID int64 `json:"applyid" xorm:"APPLYID"` // 申请人
  167. REMARK string `json:"remark" xorm:"REMARK"` // 备注
  168. CREATETIME time.Time `json:"createtime" xorm:"CREATETIME"` // 申请时间
  169. AUDITTRADEDATE string `json:"audittradedate" xorm:"AUDITTRADEDATE"` // 审核交易日(yyyyMMdd)
  170. AUDITID int64 `json:"auditid" xorm:"AUDITID"` // 审核人
  171. AUDITSRC int32 `json:"auditsrc" xorm:"AUDITSRC"` // 审核来源 - 1:管理端 2:终端
  172. AUDITTIME time.Time `json:"audittime" xorm:"AUDITTIME"` // 审核时间
  173. AUDITREMARK string `json:"auditremark" xorm:"AUDITREMARK"` // 审核备注
  174. DELIVERYGOODSID int64 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID
  175. WRSTANDARDID int64 `json:"wrstandardid" xorm:"WRSTANDARDID"` // 现货商品ID
  176. VATRATE float64 `json:"vatrate" xorm:"VATRATE"` // 增值税
  177. HEDGEQTY float64 `json:"hedgeqty" xorm:"HEDGEQTY"` // 套期现货量
  178. HEDGEAMOUNT float64 `json:"hedgeamount" xorm:"HEDGEAMOUNT"` // 套期市价总额
  179. HEDGERESTAMOUNT float64 `json:"hedgerestamount" xorm:"HEDGERESTAMOUNT"` // 套期剩余市价总额【现货贸易】
  180. HEDGECONTRACTAMOUNT float64 `json:"hedgecontractamount" xorm:"HEDGECONTRACTAMOUNT"` // 套期定价总额 【定价采购合同】【现货贸易】
  181. ORIAVGPRICE float64 `json:"oriavgprice" xorm:"ORIAVGPRICE"` // 期初市场均价 = 套期市价总额 / 套期现货量
  182. EXEQTY float64 `json:"exeqty" xorm:"EXEQTY"` // 执行现货量
  183. EXEAMOUNT float64 `json:"exeamount" xorm:"EXEAMOUNT"` // 执行市价总额
  184. EXERESTAMOUNT float64 `json:"exerestamount" xorm:"EXERESTAMOUNT"` // 执行剩余市价总额【现货贸易】
  185. EXEAVGPRICE float64 `json:"exeavgprice" xorm:"EXEAVGPRICE"` // 执行市场均价= 执行市价总额 / 执行现货量
  186. EXECONTRACTAMOUNT float64 `json:"execontractamount" xorm:"EXECONTRACTAMOUNT"` // 执行定价总额
  187. CURPRICE float64 `json:"curprice" xorm:"CURPRICE"` // 当前市场价
  188. UNEXEQTY float64 `json:"unexeqty" xorm:"UNEXEQTY"` // 未执行现货量 = 套期现货量 - 执行现货量
  189. SPOTHEDGEPL float64 `json:"spothedgepl" xorm:"SPOTHEDGEPL"` // 现货套期损益 =(执行市场均价-期初市场均价)*执行现货量 * 方向(销售计划 为 -1, 其它为1)
  190. SPOTPL float64 `json:"spotpl" xorm:"SPOTPL"` // 现货套期损益 = 现货实际损益 + 现货浮动损益
  191. FUTUREHEDGEPL float64 `json:"futurehedgepl" xorm:"FUTUREHEDGEPL"` // 期货实际损益
  192. FUTUREPL float64 `json:"futurepl" xorm:"FUTUREPL"` // 期货套期损益
  193. HEDGESUMPL float64 `json:"hedgesumpl" xorm:"HEDGESUMPL"` // 套期汇总损益 = 期货汇总损益 + 现货汇总损益
  194. SPOTTRADEPL float64 `json:"spottradepl" xorm:"SPOTTRADEPL"` // 现货贸易损益【现货贸易】= 执行合同定价总额 - 套期合同定价总额
  195. VATPL float64 `json:"vatpl" xorm:"VATPL"` // 增值税损益【现货贸易】= 现货贸易损益 * (增值税率 /(1+增值税率))
  196. SUMOBSPL float64 `json:"sumobspl" xorm:"SUMOBSPL"` // 汇总绝对损益【现货贸易】=现货贸易损益+增值税损益+期货套期损益
  197. SPOTBOOKAMOUNT float64 `json:"spotbookamount" xorm:"SPOTBOOKAMOUNT"` // 现货账面总额
  198. CURSTOCK float64 `json:"curstock" xorm:"CURSTOCK"` // 期末库存量 = 采购总量 - 销售总量
  199. ENDDATE time.Time `json:"enddate" xorm:"ENDDATE"` // 完成日期
  200. ENDTRADEDATE string `json:"endtradedate" xorm:"ENDTRADEDATE"` // 完成交易日
  201. UPDATETIME time.Time `json:"updatetime" xorm:"UPDATETIME"` // 更新时间
  202. ORISPOTHEDGEPL float64 `json:"orispothedgepl" xorm:"ORISPOTHEDGEPL"` // 期初现货实际损益
  203. ORIFUTUREHEDGEPL float64 `json:"orifuturehedgepl" xorm:"ORIFUTUREHEDGEPL"` // 期初期货实际损益
  204. ORISPOTPL float64 `json:"orispotpl" xorm:"ORISPOTPL"` // 期初现货套期损益
  205. ORIFUTUREPL float64 `json:"orifuturepl" xorm:"ORIFUTUREPL"` // 期初期货套期损益
  206. SPOTFLOATPL float64 `json:"spotfloatpl" xorm:"SPOTFLOATPL"` // 现货浮动损益 =(当前市场价 - 期初市场价)*未执行现货量 * 方向(销售计划 为 -1, 其它为1)
  207. FUTUREFLOATPL float64 `json:"futurefloatpl" xorm:"FUTUREFLOATPL"` // 期货浮动损益
  208. }
  209. // TableName is REPORT_ERMCP2_HEDGEDITEM
  210. func (r *Reportermcp2hedgeditem) TableName() string {
  211. return "REPORT_ERMCP2_HEDGEDITEM"
  212. }
  213. // Ermcp2hedgeditem 被套期项目表
  214. type Ermcp2hedgeditem struct {
  215. Hedgeditemid string `json:"hedgeditemid" xorm:"HEDGEDITEMID"` // 被套期项目ID(624+Unix秒时间戳(10位)+xxxxxx)
  216. Hedgeditemnum string `json:"hedgeditemnum" xorm:"HEDGEDITEMNUM"` // 项目编号
  217. Hedgeditemname string `json:"hedgeditemname" xorm:"HEDGEDITEMNAME"` // 项目名称
  218. Hedgedtype int32 `json:"hedgedtype" xorm:"HEDGEDTYPE" form:"hedgedtype"` // 套期类型 - 1:采购计划项目 2:销售计划项目 3:现货贸易项目 4:库存存货项目 5:定价采购合同项目
  219. Planstartdate time.Time `json:"planstartdate" xorm:"PLANSTARTDATE"` // 计划开始日期
  220. Planenddate time.Time `json:"planenddate" xorm:"PLANENDDATE"` // 计划结束日期
  221. Hedgerate float64 `json:"hedgerate" xorm:"HEDGERATE"` // 套保比率
  222. Tradeuserid int64 `json:"tradeuserid" xorm:"TRADEUSERID"` // 交易用户ID
  223. Areauserid int64 `json:"areauserid" xorm:"AREAUSERID"` // 企业ID
  224. Hedgeditemstatus int32 `json:"hedgeditemstatus" xorm:"HEDGEDITEMSTATUS" form:"hedgeditemstatus"` // 项目状态 - 0:未提交 1:待审核 2:执行中 3:正常完结 4:审核拒绝 5:异常完结 6:已撤回
  225. Applysrc int32 `json:"applysrc" xorm:"APPLYSRC"` // 申请来源 - 1:管理端 2:终端
  226. Applyid int64 `json:"applyid" xorm:"APPLYID"` // 申请人
  227. Remark string `json:"remark" xorm:"REMARK"` // 备注
  228. Createtime time.Time `json:"createtime" xorm:"CREATETIME"` // 申请时间
  229. Audittradedate string `json:"audittradedate" xorm:"AUDITTRADEDATE"` // 审核交易日(yyyyMMdd)
  230. Auditid int64 `json:"auditid" xorm:"AUDITID"` // 审核人
  231. Auditsrc int32 `json:"auditsrc" xorm:"AUDITSRC"` // 审核来源 - 1:管理端 2:终端
  232. Audittime time.Time `json:"audittime" xorm:"AUDITTIME"` // 审核时间
  233. Auditremark string `json:"auditremark" xorm:"AUDITREMARK"` // 审核备注
  234. Deliverygoodsid int64 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID
  235. Wrstandardid int64 `json:"wrstandardid" xorm:"WRSTANDARDID"` // 现货商品ID
  236. Vatrate float64 `json:"vatrate" xorm:"VATRATE"` // 增值税
  237. Hedgeqty float64 `json:"hedgeqty" xorm:"HEDGEQTY"` // 套期现货量
  238. Hedgeamount float64 `json:"hedgeamount" xorm:"HEDGEAMOUNT"` // 套期市价总额
  239. Hedgerestamount float64 `json:"hedgerestamount" xorm:"HEDGERESTAMOUNT"` // 套期剩余市价总额【现货贸易】
  240. Hedgecontractamount float64 `json:"hedgecontractamount" xorm:"HEDGECONTRACTAMOUNT"` // 套期定价总额 【定价采购合同】【现货贸易】
  241. Oriavgprice float64 `json:"oriavgprice" xorm:"ORIAVGPRICE"` // 期初市场均价 = 套期市价总额 / 套期现货量
  242. Exeqty float64 `json:"exeqty" xorm:"EXEQTY"` // 执行现货量
  243. Exeamount float64 `json:"exeamount" xorm:"EXEAMOUNT"` // 执行市价总额
  244. Exerestamount float64 `json:"exerestamount" xorm:"EXERESTAMOUNT"` // 执行剩余市价总额【现货贸易】
  245. Exeavgprice float64 `json:"exeavgprice" xorm:"EXEAVGPRICE"` // 执行市场均价= 执行市价总额 / 执行现货量
  246. Execontractamount float64 `json:"execontractamount" xorm:"EXECONTRACTAMOUNT"` // 执行定价总额
  247. Curprice float64 `json:"curprice" xorm:"CURPRICE"` // 当前市场价
  248. Unexeqty float64 `json:"unexeqty" xorm:"UNEXEQTY"` // 未执行现货量 = 套期现货量 - 执行现货量
  249. Spothedgepl float64 `json:"spothedgepl" xorm:"SPOTHEDGEPL"` // 现货套期损益 =(执行市场均价-期初市场均价)*执行现货量 * 方向(销售计划 为 -1, 其它为1)
  250. Spotpl float64 `json:"spotpl" xorm:"SPOTPL"` // 现货套期损益 = 现货实际损益 + 现货浮动损益
  251. Futurehedgepl float64 `json:"futurehedgepl" xorm:"FUTUREHEDGEPL"` // 期货实际损益
  252. Futurepl float64 `json:"futurepl" xorm:"FUTUREPL"` // 期货套期损益
  253. Hedgesumpl float64 `json:"hedgesumpl" xorm:"HEDGESUMPL"` // 套期汇总损益 = 期货汇总损益 + 现货汇总损益
  254. Spottradepl float64 `json:"spottradepl" xorm:"SPOTTRADEPL"` // 现货贸易损益【现货贸易】= 执行合同定价总额 - 套期合同定价总额
  255. Vatpl float64 `json:"vatpl" xorm:"VATPL"` // 增值税损益【现货贸易】= 现货贸易损益 * (增值税率 /(1+增值税率))
  256. Sumobspl float64 `json:"sumobspl" xorm:"SUMOBSPL"` // 汇总绝对损益【现货贸易】=现货贸易损益+增值税损益+期货套期损益
  257. Spotbookamount float64 `json:"spotbookamount" xorm:"SPOTBOOKAMOUNT"` // 现货账面总额
  258. Curstock float64 `json:"curstock" xorm:"CURSTOCK"` // 期末库存量 = 采购总量 - 销售总量
  259. Enddate time.Time `json:"enddate" xorm:"ENDDATE"` // 完成日期
  260. Endtradedate string `json:"endtradedate" xorm:"ENDTRADEDATE"` // 完成交易日
  261. Updatetime time.Time `json:"updatetime" xorm:"UPDATETIME"` // 更新时间
  262. Orispothedgepl float64 `json:"orispothedgepl" xorm:"ORISPOTHEDGEPL"` // 期初现货实际损益
  263. Orifuturehedgepl float64 `json:"orifuturehedgepl" xorm:"ORIFUTUREHEDGEPL"` // 期初期货实际损益
  264. Orispotpl float64 `json:"orispotpl" xorm:"ORISPOTPL"` // 期初现货套期损益
  265. Orifuturepl float64 `json:"orifuturepl" xorm:"ORIFUTUREPL"` // 期初期货套期损益
  266. Spotfloatpl float64 `json:"spotfloatpl" xorm:"SPOTFLOATPL"` // 现货浮动损益 =(当前市场价 - 期初市场价)*未执行现货量 * 方向(销售计划 为 -1, 其它为1)
  267. Futurefloatpl float64 `json:"futurefloatpl" xorm:"FUTUREFLOATPL"` // 期货浮动损益
  268. SpotHedgePLChange float64 `json:"spothedgeplchange" xorm:"SPOTHEDGEPLCHANGE"` // 现货实际损益变动
  269. SpotPLChange float64 `json:"spotplchange" xorm:"SPOTPLCHANGE"` // 现货套期损益变动
  270. FutureHedgePLChange float64 `json:"futurehedgeplchange" xorm:"FUTUREHEDGEPLCHANGE"` // 期货实际损益变动
  271. FuturePLChange float64 `json:"futureplchange" xorm:"FUTUREPLCHANGE"` // 期货套期损益变动
  272. Wrstandardname string `json:"wrstandardname" xorm:"WRSTANDARDNAME"` // 商品名称
  273. EnumdicName string `json:"enumdicname" xorm:"ENUMDICNAME"` // 单位
  274. AccountName string `json:"accountName" xorm:"ACCOUNTNAME"` // 套期主体
  275. MiddleGoodsList []Ermcp2himiddlegoods `json:"middlegoodslist"` // 套期商品列表
  276. USERID int64 `json:"-" form:"userid" binding:"required"` // 用户id, 用于过滤
  277. }
  278. // TableName is ERMCP2_HEDGEDITEM
  279. func (r *Ermcp2hedgeditem) TableName() string {
  280. return "ERMCP2_HEDGEDITEM"
  281. }
  282. func (r *Ermcp2hedgeditem) calc() {
  283. }
  284. func (r *Ermcp2hedgeditem) buildSql() string {
  285. var sqlId utils.SQLVal = `
  286. SELECT
  287. to_char(t.HEDGEDITEMID) HEDGEDITEMID,
  288. t.HEDGEDITEMNUM ,
  289. t.HEDGEDITEMNAME ,
  290. t.HEDGEDTYPE ,
  291. t.PLANSTARTDATE ,
  292. t.PLANENDDATE ,
  293. t.HEDGERATE ,
  294. t.TRADEUSERID ,
  295. t.AREAUSERID ,
  296. t.HEDGEDITEMSTATUS ,
  297. t.APPLYSRC ,
  298. t.APPLYID ,
  299. t.REMARK ,
  300. t.CREATETIME ,
  301. t.AUDITTRADEDATE ,
  302. t.AUDITID ,
  303. t.AUDITSRC ,
  304. t.AUDITTIME ,
  305. t.AUDITREMARK ,
  306. t.DELIVERYGOODSID ,
  307. t.WRSTANDARDID ,
  308. t.VATRATE ,
  309. t.HEDGEQTY ,
  310. t.HEDGEAMOUNT ,
  311. t.HEDGERESTAMOUNT ,
  312. t.HEDGECONTRACTAMOUNT,
  313. t.ORIAVGPRICE ,
  314. t.EXEQTY ,
  315. t.EXEAMOUNT ,
  316. t.EXERESTAMOUNT ,
  317. t.EXEAVGPRICE ,
  318. t.EXECONTRACTAMOUNT ,
  319. t.CURPRICE ,
  320. t.UNEXEQTY ,
  321. t.SPOTHEDGEPL ,
  322. t.SPOTPL ,
  323. t.FUTUREHEDGEPL ,
  324. t.FUTUREPL ,
  325. t.HEDGESUMPL ,
  326. t.SPOTTRADEPL ,
  327. t.VATPL ,
  328. t.SUMOBSPL ,
  329. t.SPOTBOOKAMOUNT ,
  330. t.CURSTOCK ,
  331. t.ENDDATE ,
  332. t.ENDTRADEDATE ,
  333. t.UPDATETIME ,
  334. t.ORISPOTHEDGEPL ,
  335. t.ORIFUTUREHEDGEPL ,
  336. t.ORISPOTPL ,
  337. t.ORIFUTUREPL ,
  338. t.SPOTFLOATPL ,
  339. t.FUTUREFLOATPL ,
  340. (t.SpotHedgePL - t.OriSpotHedgePL) SPOTHEDGEPLCHANGE,
  341. (t.SpotPL - t.OriSpotPL) SPOTPLCHANGE,
  342. (t.FutureHedgePL - t.OriFutureHedgePL) FUTUREHEDGEPLCHANGE,
  343. (t.FuturePL - t.OriFuturePL) FUTUREPLCHANGE,
  344. wr.WRSTANDARDNAME,
  345. e.ENUMDICNAME,
  346. u.ACCOUNTNAME
  347. FROM ERMCP2_HedgedItem t
  348. LEFT JOIN WRStandard wr ON wr.wrstandardid = t.wrstandardid
  349. LEFT JOIN enumdicitem e on wr.unitid=e.enumitemname and e.enumdiccode='goodsunit'
  350. LEFT JOIN useraccount u ON u.userid = t.tradeuserid
  351. WHERE 1 = 1
  352. AND %v in (t.AreaUserID, t.TradeUserID)
  353. `
  354. sqlId.FormatParam(r.USERID)
  355. sqlId.AndEx("t.Hedgedtype", r.Hedgedtype, r.Hedgedtype > 0)
  356. sqlId.AndEx("t.hedgeditemstatus", r.Hedgeditemstatus, r.Hedgeditemstatus > 0)
  357. return sqlId.String()
  358. }
  359. // GetDataEx 从数据库中查询数据
  360. func (r *Ermcp2hedgeditem) GetDataEx() (interface{}, error) {
  361. e := db.GetEngine()
  362. s := e.SQL(r.buildSql())
  363. sData := make([]Ermcp2hedgeditem, 0)
  364. if err := s.Find(&sData); err != nil {
  365. return nil, err
  366. }
  367. for i := range sData {
  368. sData[i].calc()
  369. }
  370. if len(sData) > 0 {
  371. // 获取关联期货品种
  372. m1 := Ermcp2himiddlegoods{}
  373. if d1, err := m1.GetDataEx(); err == nil {
  374. gpLst := d1.([]Ermcp2himiddlegoods)
  375. for i := range sData {
  376. sData[i].MiddleGoodsList = append(sData[i].MiddleGoodsList, gpLst...)
  377. }
  378. }
  379. }
  380. return sData, nil
  381. }
  382. // Ermcp2himiddlegoods 项目套保品种明细
  383. type Ermcp2himiddlegoods struct {
  384. HEDGEDITEMID int64 `json:"hedgeditemid" xorm:"HEDGEDITEMID" binding:"required"` // 被套期项目ID(624+Unix秒时间戳(10位)+xxxxxx)
  385. MIDDLEGOODSID int64 `json:"middlegoodsid" xorm:"MIDDLEGOODSID" binding:"required"` // 套保品种ID
  386. DELIVERYGOODSID int64 `json:"-" xorm:"DELIVERYGOODSID"` // 现货品种ID
  387. WRSTANDARDID int64 `json:"-" xorm:"WRSTANDARDID"` // 现货商品ID
  388. VATRATE float64 `json:"-" xorm:"VATRATE"` // 增值税
  389. SPOTCONVERTRATIO float64 `json:"-" xorm:"SPOTCONVERTRATIO"` // 折算系数 [现货]
  390. UNEXESPOTQTY float64 `json:"-" xorm:"UNEXESPOTQTY"` // 未执行现货量
  391. UNEXEHEDGEQTY float64 `json:"unexehedgeqty" xorm:"UNEXEHEDGEQTY"` // 未执行套期量 = 未执行现货量*折算系数* (1/(1+增值税)) * 套期比例(项目上)
  392. FUTUREHEDGEQTY float64 `json:"futurehedgeqty" xorm:"FUTUREHEDGEQTY"` // 期货持仓套期量
  393. HIEXPSOURE float64 `json:"hiexpsoure" xorm:"HIEXPSOURE"` // 期现敞口量 = 未执行套期量 + 期货持仓套期量
  394. TRADEUSERID int64 `json:"-" xorm:"TRADEUSERID"` // 交易用户ID
  395. AREAUSERID int64 `json:"-" xorm:"AREAUSERID"` // 企业ID
  396. CREATETIME time.Time `json:"-" xorm:"CREATETIME"` // 创建时间
  397. UPDATETIME time.Time `json:"-" xorm:"UPDATETIME"` // 更新时间
  398. Middlegoodsname string `json:"middlegoodsname" xorm:"MIDDLEGOODSNAME"` // 套保商品名称
  399. Middlegoodscode string `json:"middlegoodscode" xorm:"MIDDLEGOODSCODE"` // 套保商品代码
  400. }
  401. // TableName is ERMCP2_HIMIDDLEGOODS
  402. func (r *Ermcp2himiddlegoods) TableName() string {
  403. return "ERMCP2_HIMIDDLEGOODS"
  404. }
  405. func (r *Ermcp2himiddlegoods) calc() {
  406. }
  407. func (r *Ermcp2himiddlegoods) buildSql() string {
  408. var sqlId utils.SQLVal = `
  409. SELECT
  410. t.MIDDLEGOODSID,
  411. t.UNEXEHEDGEQTY,
  412. t.FUTUREHEDGEQTY,
  413. t.HIEXPSOURE,
  414. m.MIDDLEGOODSNAME,
  415. m.MIDDLEGOODSCODE
  416. FROM ERMCP2_HIMIDDLEGOODS t
  417. LEFT JOIN erms_middlegoods m ON m.middlegoodsid = t.middlegoodsid
  418. WHERE t.HEDGEDITEMID = %v
  419. `
  420. sqlId.FormatParam(r.HEDGEDITEMID)
  421. return sqlId.String()
  422. }
  423. // GetDataEx 从数据库中查询数据
  424. func (r *Ermcp2himiddlegoods) GetDataEx() (interface{}, error) {
  425. e := db.GetEngine()
  426. s := e.SQL(r.buildSql())
  427. sData := make([]Ermcp2himiddlegoods, 0)
  428. if err := s.Find(&sData); err != nil {
  429. return nil, err
  430. }
  431. for i := range sData {
  432. sData[i].calc()
  433. }
  434. return sData, nil
  435. }
  436. // Ermcpjrlinkpos 项目期货关联头寸
  437. type Ermcpjrlinkpos struct {
  438. SPOTCONTRACTID string `json:"spotcontractid" xorm:"SPOTCONTRACTID" form:"hedgeditemid" binding:"required"` // 现货ID [套期项目ID - 金瑞:合同\虚拟合同ID
  439. GOODSID int32 `json:"goodsid" xorm:"GOODSID"` // 期货合约
  440. ORDERTYPE int32 `json:"ordertype" xorm:"ORDERTYPE"` // 单据类型[套期工具] - 1:期货单 2:看涨期权单 3:看跌期权单
  441. EXECUTEPRICE int64 `json:"executeprice" xorm:"EXECUTEPRICE"` // 执行价 - 1:期货单 为 0
  442. OPTIONCODE string `json:"optioncode" xorm:"OPTIONCODE"` // 期权代码
  443. AREAUSERID int64 `json:"areauserid" xorm:"AREAUSERID"` // 所属企业
  444. TOTALBUYAMOUNT float64 `json:"totalbuyamount" xorm:"TOTALBUYAMOUNT"` // 买金额 [期货]
  445. TOTALBUYQTY float64 `json:"totalbuyqty" xorm:"TOTALBUYQTY"` // 买数量
  446. TOTALSELLAMOUNT float64 `json:"totalsellamount" xorm:"TOTALSELLAMOUNT"` // 卖金额 [期货]
  447. TOTALSELLQTY float64 `json:"totalsellqty" xorm:"TOTALSELLQTY"` // 卖数量
  448. NETQTY float64 `json:"netqty" xorm:"NETQTY"` // 净头寸
  449. TOTALCHARGE float64 `json:"totalcharge" xorm:"TOTALCHARGE"` // 手续费
  450. TOTALPREMIUM float64 `json:"totalpremium" xorm:"TOTALPREMIUM"` // 权利金 [期权]
  451. CLOSEPL float64 `json:"closepl" xorm:"CLOSEPL"` // 总平仓盈亏 [期货损益]
  452. UPDATETIME time.Time `json:"updatetime" xorm:"UPDATETIME"` // 更新时间
  453. TOTALBUYHOLDAMOUNT float64 `json:"totalbuyholdamount" xorm:"TOTALBUYHOLDAMOUNT"` // 买持仓总金额[期货]
  454. TOTALSELLHOLDAMOUNT float64 `json:"totalsellholdamount" xorm:"TOTALSELLHOLDAMOUNT"` // 卖持仓总金额[期货]
  455. TODAYFUTURECLOSEPL float64 `json:"todayfutureclosepl" xorm:"TODAYFUTURECLOSEPL"` // 今日平仓盈亏
  456. RECKONPL float64 `json:"reckonpl" xorm:"RECKONPL"` // 总盈亏(平仓盈亏 + 结算盈亏 - 手续费)
  457. Middlegoodsname string `json:"middlegoodsname" xorm:"MIDDLEGOODSNAME"` // 套保商品名称
  458. Middlegoodscode string `json:"middlegoodscode" xorm:"MIDDLEGOODSCODE"` // 套保商品代码
  459. FUTUREHEDGEQTY float64 `json:"futurehedgeqty" xorm:"FUTUREHEDGEQTY"` // 期货套期量
  460. AVERAGEPRICE float64 `json:"averageprice" xorm:"AVERAGEPRICE"` // 持仓均价 (TotalBuyHoldAmount - TotalSellHoldAmount) / NetQty
  461. }
  462. // TableName is ERMCP_JR_LINKPOS
  463. func (r *Ermcpjrlinkpos) TableName() string {
  464. return "ERMCP_JR_LINKPOS"
  465. }
  466. func (r *Ermcpjrlinkpos) calc() {
  467. }
  468. func (r *Ermcpjrlinkpos) buildSql() string {
  469. var sqlId utils.SQLVal = `
  470. SELECT
  471. to_char(t.SPOTCONTRACTID) SPOTCONTRACTID,
  472. t.ORDERTYPE,
  473. t.OPTIONCODE,
  474. t.CLOSEPL,
  475. t.NETQTY,
  476. ((t.TotalBuyHoldAmount - t.TotalSellHoldAmount) / NetQty) AVERAGEPRICE,
  477. mg.middlegoodsname,
  478. mg.middlegoodscode
  479. FROM ERMCP_JR_LinkPos t
  480. LEFT JOIN Goods g ON g.goodsid = t.goodsid
  481. LEFT JOIN ERMCP_GGConvertConfig gc on gc.srcgoodsgroupid = g.goodsgroupid
  482. LEFT JOIN ERMS_MiddleGoods mg ON mg.goodsgroupid = gc.destgoodsgroupid
  483. WHERE mg.areauserid = t.areauserid AND t.SPOTCONTRACTID = %v
  484. ORDER BY t.OPTIONCODE
  485. `
  486. // 只有期货合约ID(GoodsID)的情况下获取套保商品名称,需要以上的关联
  487. sqlId.FormatParam(r.SPOTCONTRACTID)
  488. return sqlId.String()
  489. }
  490. // GetDataEx 从数据库中查询数据
  491. func (r *Ermcpjrlinkpos) GetDataEx() (interface{}, error) {
  492. e := db.GetEngine()
  493. s := e.SQL(r.buildSql())
  494. sData := make([]Ermcpjrlinkpos, 0)
  495. if err := s.Find(&sData); err != nil {
  496. return nil, err
  497. }
  498. for i := range sData {
  499. sData[i].calc()
  500. }
  501. return sData, nil
  502. }
  503. // Ermcp2hedgeditemspot 项目现货明细
  504. type Ermcp2hedgeditemspot struct {
  505. HEDGEDITEMSPOTID string `json:"hedgeditemspotid" xorm:"HEDGEDITEMSPOTID"` // 现货明细ID(625+Unix秒时间戳(10位)+xxxxxx)
  506. HEDGEDITEMID string `json:"hedgeditemid" xorm:"HEDGEDITEMID" form:"hedgeditemid" binding:"required"` // 被套期项目ID
  507. HEDGEDTYPE int32 `json:"hedgedtype" xorm:"HEDGEDTYPE"` // 套期类型[计划类型] - 1:采购计划项目 2:销售计划项目 3:现货贸易项目 4:库存存货项目 5:定价采购合同项目
  508. SPOTTYPE int32 `json:"spottype" xorm:"SPOTTYPE"` // 现货类型 - 1:采购计划 2:销售计划 3:采购合同 4:销售合同 5:库存存货
  509. RELATEDTYPE int32 `json:"relatedtype" xorm:"RELATEDTYPE"` // 关联类型 - 1:套期关联 2:执行关联
  510. RELATEDHEDGEPLANID int64 `json:"relatedhedgeplanid" xorm:"RELATEDHEDGEPLANID"` // 关联计划ID 【1:采购计划 2:销售计划】
  511. RELATEDSPOTCONTRACTID int64 `json:"relatedspotcontractid" xorm:"RELATEDSPOTCONTRACTID"` // 关联合同ID 【3:采购合同 4:销售合同】
  512. CUSTOMERUSERID int64 `json:"customeruserid" xorm:"CUSTOMERUSERID"` // 对手方 【3:采购合同 4:销售合同】
  513. DELIVERYGOODSID int64 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID
  514. WRSTANDARDID int64 `json:"wrstandardid" xorm:"WRSTANDARDID"` // 现货商品ID
  515. SPOTGOODSBRANDID int32 `json:"spotgoodsbrandid" xorm:"SPOTGOODSBRANDID"` // 现货品牌ID - 存“DGFactoryItem”表"DGFactoryItemID" = 2
  516. RELATEDQTY float64 `json:"relatedqty" xorm:"RELATEDQTY"` // 关联数量[数量]
  517. ORIAVGPRICE float64 `json:"oriavgprice" xorm:"ORIAVGPRICE"` // 期初市场价[当初市场价]
  518. RELATEDAMOUNT float64 `json:"relatedamount" xorm:"RELATEDAMOUNT"` // 市价总额 = 关联数量 * 期初市场价
  519. SPOTPRICEDAMOUNT float64 `json:"spotpricedamount" xorm:"SPOTPRICEDAMOUNT"` // 定价总额
  520. SPOTPRICEDAVGPRICE float64 `json:"spotpricedavgprice" xorm:"SPOTPRICEDAVGPRICE"` // 现货均价 = 定价总额 / 关联数量
  521. CREATETIME time.Time `json:"createtime" xorm:"CREATETIME"` // 创建时间
  522. TRADEUSERID int64 `json:"tradeuserid" xorm:"TRADEUSERID"` // 交易用户ID
  523. AREAUSERID int64 `json:"areauserid" xorm:"AREAUSERID"` // 企业ID
  524. Wrstandardname string `json:"wrstandardname" xorm:"WRSTANDARDNAME"` // 现货商品
  525. EnumdicName string `json:"enumdicname" xorm:"ENUMDICNAME"` // 单位
  526. Hedgeplanno string `json:"hedgeplanno" xorm:"HEDGEPLANNO"` // 计划编号
  527. }
  528. // TableName is ERMCP2_HEDGEDITEMSPOT
  529. func (r *Ermcp2hedgeditemspot) TableName() string {
  530. return "ERMCP2_HEDGEDITEMSPOT"
  531. }
  532. func (r *Ermcp2hedgeditemspot) calc() {
  533. }
  534. func (r *Ermcp2hedgeditemspot) buildSql() string {
  535. var sqlId utils.SQLVal = `
  536. SELECT
  537. to_char(t.hedgeditemspotid) HEDGEDITEMSPOTID,
  538. to_char(t.hedgeditemid) HEDGEDITEMID,
  539. t.HEDGEDTYPE,
  540. wr.WRSTANDARDNAME,
  541. e.ENUMDICNAME,
  542. t.RELATEDQTY,
  543. t.ORIAVGPRICE,
  544. s.HEDGEPLANNO
  545. FROM ERMCP2_HEDGEDITEMSPOT t
  546. LEFT JOIN WRStandard wr ON wr.wrstandardid = t.wrstandardid
  547. LEFT JOIN enumdicitem e on wr.unitid=e.enumitemname and e.enumdiccode='goodsunit'
  548. LEFT JOIN ermcp_hedgeplan s ON s.HedgePlanID = t.RELATEDHEDGEPLANID
  549. WHERE t.HedgedType IN (1,2) AND t.hedgeditemid = %v
  550. ORDER BY t.createtime
  551. `
  552. sqlId.FormatParam(r.HEDGEDITEMID)
  553. return sqlId.String()
  554. }
  555. // GetDataEx 从数据库中查询数据
  556. func (r *Ermcp2hedgeditemspot) GetDataEx() (interface{}, error) {
  557. e := db.GetEngine()
  558. s := e.SQL(r.buildSql())
  559. sData := make([]Ermcp2hedgeditemspot, 0)
  560. if err := s.Find(&sData); err != nil {
  561. return nil, err
  562. }
  563. for i := range sData {
  564. sData[i].calc()
  565. }
  566. return sData, nil
  567. }
  568. // Ermcp2hedgeditemspotDetail 现货成交明细
  569. type Ermcp2hedgeditemspotDetail struct {
  570. HEDGEDITEMSPOTID string `json:"hedgeditemspotid" xorm:"HEDGEDITEMSPOTID"` // 现货明细ID(625+Unix秒时间戳(10位)+xxxxxx)
  571. HEDGEDITEMID string `json:"hedgeditemid" xorm:"HEDGEDITEMID" form:"hedgeditemid" binding:"required"` // 被套期项目ID
  572. HEDGEDTYPE int32 `json:"hedgedtype" xorm:"HEDGEDTYPE"` // 套期类型[计划类型] - 1:采购计划项目 2:销售计划项目 3:现货贸易项目 4:库存存货项目 5:定价采购合同项目
  573. SPOTTYPE int32 `json:"spottype" xorm:"SPOTTYPE"` // 现货类型[合同类型] - 1:采购计划 2:销售计划 3:采购合同 4:销售合同 5:库存存货
  574. RELATEDTYPE int32 `json:"relatedtype" xorm:"RELATEDTYPE"` // 关联类型 - 1:套期关联 2:执行关联
  575. RELATEDHEDGEPLANID int64 `json:"relatedhedgeplanid" xorm:"RELATEDHEDGEPLANID"` // 关联计划ID 【1:采购计划 2:销售计划】
  576. RELATEDSPOTCONTRACTID int64 `json:"relatedspotcontractid" xorm:"RELATEDSPOTCONTRACTID"` // 关联合同ID 【3:采购合同 4:销售合同】
  577. CUSTOMERUSERID int64 `json:"customeruserid" xorm:"CUSTOMERUSERID"` // 对手方 【3:采购合同 4:销售合同】
  578. DELIVERYGOODSID int64 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID
  579. WRSTANDARDID int64 `json:"wrstandardid" xorm:"WRSTANDARDID"` // 现货商品ID
  580. SPOTGOODSBRANDID int32 `json:"spotgoodsbrandid" xorm:"SPOTGOODSBRANDID"` // 现货品牌ID - 存“DGFactoryItem”表"DGFactoryItemID" = 2
  581. RELATEDQTY float64 `json:"relatedqty" xorm:"RELATEDQTY"` // 关联数量[数量]
  582. ORIAVGPRICE float64 `json:"oriavgprice" xorm:"ORIAVGPRICE"` // 期初市场价[当初市场价]
  583. RELATEDAMOUNT float64 `json:"relatedamount" xorm:"RELATEDAMOUNT"` // 市价总额 = 关联数量 * 期初市场价
  584. SPOTPRICEDAMOUNT float64 `json:"spotpricedamount" xorm:"SPOTPRICEDAMOUNT"` // 定价总额[金额]
  585. SPOTPRICEDAVGPRICE float64 `json:"spotpricedavgprice" xorm:"SPOTPRICEDAVGPRICE"` // 现货均价 = 定价总额 / 关联数量
  586. CREATETIME time.Time `json:"createtime" xorm:"CREATETIME"` // 创建时间
  587. TRADEUSERID int64 `json:"tradeuserid" xorm:"TRADEUSERID"` // 交易用户ID
  588. AREAUSERID int64 `json:"areauserid" xorm:"AREAUSERID"` // 企业ID
  589. Wrstandardname string `json:"wrstandardname" xorm:"WRSTANDARDNAME"` // 现货商品
  590. EnumdicName string `json:"enumdicname" xorm:"ENUMDICNAME"` // 单位
  591. AccountName string `json:"accountName" xorm:"ACCOUNTNAME"` // 对手方
  592. BRANDNAME string `json:"brandname" xorm:"BRANDNAME"` // 品牌
  593. CONTRACTNO string `json:"contractno" xorm:"CONTRACTNO"` // 合同编号
  594. }
  595. func (r *Ermcp2hedgeditemspotDetail) calc() {
  596. }
  597. func (r *Ermcp2hedgeditemspotDetail) buildSql() string {
  598. var sqlId utils.SQLVal = `
  599. SELECT
  600. to_char(t.hedgeditemspotid) HEDGEDITEMSPOTID,
  601. to_char(t.hedgeditemid) HEDGEDITEMID,
  602. t.CREATETIME,
  603. t.SPOTTYPE,
  604. u.ACCOUNTNAME,
  605. wr.WRSTANDARDNAME,
  606. e.ENUMDICNAME,
  607. gb.dgfactoryitemvalue BRANDNAME,
  608. t.RELATEDQTY,
  609. t.SPOTPRICEDAVGPRICE,
  610. t.SPOTPRICEDAMOUNT,
  611. t.ORIAVGPRICE,
  612. s.CONTRACTNO
  613. FROM ERMCP2_HEDGEDITEMSPOT t
  614. LEFT JOIN useraccount u ON u.userid = t.CUSTOMERUSERID
  615. LEFT JOIN WRStandard wr ON wr.wrstandardid = t.wrstandardid
  616. LEFT JOIN enumdicitem e on wr.unitid=e.enumitemname and e.enumdiccode='goodsunit'
  617. LEFT JOIN dgfactoryitem gb ON gb.dgfactoryitemid = t.SPOTGOODSBRANDID
  618. LEFT JOIN ermcp_spotcontract s on s.spotcontractid = t.RELATEDSPOTCONTRACTID
  619. WHERE t.HedgedType IN (3,4,5) AND t.hedgeditemid = %v
  620. ORDER BY t.createtime
  621. `
  622. sqlId.FormatParam(r.HEDGEDITEMID)
  623. return sqlId.String()
  624. }
  625. // GetDataEx 从数据库中查询数据
  626. func (r *Ermcp2hedgeditemspotDetail) GetDataEx() (interface{}, error) {
  627. e := db.GetEngine()
  628. s := e.SQL(r.buildSql())
  629. sData := make([]Ermcp2hedgeditemspotDetail, 0)
  630. if err := s.Find(&sData); err != nil {
  631. return nil, err
  632. }
  633. for i := range sData {
  634. sData[i].calc()
  635. }
  636. return sData, nil
  637. }
  638. // Ermcppatradelinkdetail 期货成交单关联明细表
  639. type Ermcppatradelinkdetail struct {
  640. LINKDETAILID string `json:"linkdetailid" xorm:"LINKDETAILID"` // 期货明细ID(614+Unix秒时间戳(10位)+xxxxxx)
  641. TRADEID string `json:"tradeid" xorm:"TRADEID"` // [成交单号]内部成交单ID
  642. BUYORSELL int32 `json:"buyorsell" xorm:"BUYORSELL"` // 方向 - 0:买 1:卖
  643. HEDGEFLAG int32 `json:"hedgeflag" xorm:"HEDGEFLAG"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利 4:套期保值(平安\合同) 5:单边(平安) 6:移仓(平安) 7:错单处理(平安) 8:跨期套利(平安) 9:套期保值(计划) 10:套利(合同) 11:换月(合同) 12:交割(金瑞) 13:被套期项目
  644. SPOTCONTRACTID int64 `json:"hedgeditemid" xorm:"SPOTCONTRACTID" form:"hedgeditemid" binding:"required"` // 现货ID[套期项目ID] [13 - 被套期项目ID] [4,10,11 - 现货合同ID] [9 - 套保计划ID]
  645. RELATEDLOT float64 `json:"relatedlot" xorm:"RELATEDLOT"` // [数量]关联手数
  646. GOODSID int32 `json:"goodsid" xorm:"GOODSID"` // 商品ID
  647. GOODSGROUPID int32 `json:"goodsgroupid" xorm:"GOODSGROUPID"` // 对冲品种ID[期货合约商品组ID]
  648. MIDDLEGOODSID int64 `json:"middlegoodsid" xorm:"MIDDLEGOODSID"` // 套保品种ID
  649. RELATEDQTY float64 `json:"relatedqty" xorm:"RELATEDQTY"` // 关联数量 = RelatedLot * AgreeUnit * ConvertRatio
  650. TRADEDATE string `json:"tradedate" xorm:"TRADEDATE"` // 关联交易日(yyyyMMdd)
  651. RELATEDMODE int32 `json:"relatedmode" xorm:"RELATEDMODE"` // 关联方式 - 1:自动关联 2:手动关联 3:解绑关联
  652. TRADETRADEDATE string `json:"tradetradedate" xorm:"TRADETRADEDATE"` // 成交交易日(yyyyMMdd)
  653. TRADEPRICE float64 `json:"tradeprice" xorm:"TRADEPRICE"` // [价格]成交价格
  654. TRADELOT int64 `json:"tradelot" xorm:"TRADELOT"` // 成交手数
  655. SALEUSERID int64 `json:"saleuserid" xorm:"SALEUSERID"` // 业务员ID
  656. BIZSUBJECTID int64 `json:"bizsubjectid" xorm:"BIZSUBJECTID"` // 归属业务部门ID - SubjectID
  657. AGREEUNIT float64 `json:"agreeunit" xorm:"AGREEUNIT"` // 合约乘数
  658. CONVERTRATIO float64 `json:"convertratio" xorm:"CONVERTRATIO"` // 品种系数
  659. AREAUSERID int64 `json:"areauserid" xorm:"AREAUSERID"` // 所属机构
  660. CREATORSRC int32 `json:"creatorsrc" xorm:"CREATORSRC"` // 创建人来源 - 1:管理端 2:终端 3:交易
  661. CREATORID int64 `json:"creatorid" xorm:"CREATORID"` // 创建人ID
  662. CREATETIME time.Time `json:"createtime" xorm:"CREATETIME"` // 创建时间
  663. LINKSTATUS int32 `json:"linkstatus" xorm:"LINKSTATUS"` // 关联状态 - 1:成功 2:失败 3:解绑
  664. RETCODE int32 `json:"retcode" xorm:"RETCODE"` // 返回码
  665. TRADETIME time.Time `json:"tradetime" xorm:"TRADETIME"` // 日期时间
  666. ORDERTYPE int32 `json:"ordertype" xorm:"ORDERTYPE"` // 单据类型[套期工具] - 1:期货单 2:看涨期权单 3:看跌期权单
  667. OPTIONCODE string `json:"optioncode" xorm:"OPTIONCODE"` // [期货合约]期权代码 [期权]
  668. AMOUNT float64 `json:"amount" xorm:"AMOUNT"` // 金额 = RelatedLot * TradePrice * AgreeUnit
  669. NAME string `json:"name" xorm:"NAME"` // 账户名/子账户
  670. }
  671. func (r *Ermcppatradelinkdetail) calc() {
  672. }
  673. func (r *Ermcppatradelinkdetail) buildSql() string {
  674. var sqlId utils.SQLVal = `
  675. SELECT
  676. p.TRADETIME,
  677. p.ORDERTYPE,
  678. p.OPTIONCODE,
  679. t.BUYORSELL,
  680. t.TRADEPRICE,
  681. t.RELATEDLOT,
  682. (t.RelatedLot * t.TradePrice * t.AgreeUnit) AMOUNT,
  683. to_char(t.TRADEID) TRADEID,
  684. (u.ACCOUNTNAME || '/' || to_char(t.ACCOUNTID)) NAME
  685. FROM ERMCP_PA_TradeLinkDetail t
  686. LEFT JOIN ERMCP_PA_TradeLink p ON p.TradeID = t.TradeID AND p.BuyorSell = t.BuyorSell
  687. LEFT JOIN TAACCOUNT ta ON ta.ACCOUNTID = t.ACCOUNTID
  688. LEFT JOIN USERACCOUNT u on u.userid = ta.relateduserid
  689. WHERE t.HedgeFlag = 13 AND t.SpotContractID = %v
  690. ORDER BY p.TradeTime
  691. `
  692. sqlId.FormatParam(r.SPOTCONTRACTID)
  693. return sqlId.String()
  694. }
  695. // GetDataEx 从数据库中查询数据
  696. func (r *Ermcppatradelinkdetail) GetDataEx() (interface{}, error) {
  697. e := db.GetEngine()
  698. s := e.SQL(r.buildSql())
  699. sData := make([]Ermcppatradelinkdetail, 0)
  700. if err := s.Find(&sData); err != nil {
  701. return nil, err
  702. }
  703. for i := range sData {
  704. sData[i].calc()
  705. }
  706. return sData, nil
  707. }
  708. // InternalUncorrelatedTradeDetail 内部未关联成交单
  709. type InternalUncorrelatedTradeDetail struct {
  710. LINKDETAILID string `json:"linkdetailid" xorm:"LINKDETAILID"` // 期货明细ID(614+Unix秒时间戳(10位)+xxxxxx)
  711. TRADEID string `json:"tradeid" xorm:"TRADEID" form:"tradeid"` // 成交单号
  712. BUYORSELL int32 `json:"buyorsell" xorm:"BUYORSELL" form:"buyorsell"` // 方向 - 0:买 1:卖
  713. HEDGEFLAG int32 `json:"hedgeflag" xorm:"HEDGEFLAG"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利 4:套期保值(平安\合同) 5:单边(平安) 6:移仓(平安) 7:错单处理(平安) 8:跨期套利(平安) 9:套期保值(计划) 10:套利(合同) 11:换月(合同) 12:交割(金瑞) 13:被套期项目
  714. SPOTCONTRACTID int64 `json:"hedgeditemid" xorm:"SPOTCONTRACTID"` // 现货ID[套期项目ID] [13 - 被套期项目ID] [4,10,11 - 现货合同ID] [9 - 套保计划ID]
  715. RELATEDLOT float64 `json:"relatedlot" xorm:"RELATEDLOT"` // [数量]关联手数
  716. GOODSID int32 `json:"goodsid" xorm:"GOODSID"` // 商品ID
  717. GOODSGROUPID int32 `json:"goodsgroupid" xorm:"GOODSGROUPID"` // 对冲品种ID[期货合约商品组ID]
  718. MIDDLEGOODSID int64 `json:"middlegoodsid" xorm:"MIDDLEGOODSID"` // 套保品种ID
  719. RELATEDQTY float64 `json:"relatedqty" xorm:"RELATEDQTY"` // [套期商品数量]关联数量 = RelatedLot * AgreeUnit * ConvertRatio
  720. TRADEDATE string `json:"tradedate" xorm:"TRADEDATE"` // 关联交易日(yyyyMMdd)
  721. RELATEDMODE int32 `json:"relatedmode" xorm:"RELATEDMODE"` // 关联方式 - 1:自动关联 2:手动关联 3:解绑关联
  722. TRADETRADEDATE string `json:"tradetradedate" xorm:"TRADETRADEDATE"` // 成交交易日(yyyyMMdd)
  723. TRADEPRICE float64 `json:"tradeprice" xorm:"TRADEPRICE"` // 成交价
  724. TRADELOT int64 `json:"tradelot" xorm:"TRADELOT"` // 成交手数
  725. SALEUSERID int64 `json:"saleuserid" xorm:"SALEUSERID"` // 业务员ID
  726. BIZSUBJECTID int64 `json:"bizsubjectid" xorm:"BIZSUBJECTID"` // 归属业务部门ID - SubjectID
  727. AGREEUNIT float64 `json:"agreeunit" xorm:"AGREEUNIT"` // 合约乘数
  728. CONVERTRATIO float64 `json:"convertratio" xorm:"CONVERTRATIO"` // 品种系数
  729. AREAUSERID int64 `json:"areauserid" xorm:"AREAUSERID"` // 所属机构
  730. CREATORSRC int32 `json:"creatorsrc" xorm:"CREATORSRC"` // 创建人来源 - 1:管理端 2:终端 3:交易
  731. CREATORID int64 `json:"creatorid" xorm:"CREATORID"` // 创建人ID
  732. CREATETIME time.Time `json:"createtime" xorm:"CREATETIME"` // 创建时间
  733. LINKSTATUS int32 `json:"linkstatus" xorm:"LINKSTATUS"` // 关联状态 - 1:成功 2:失败 3:解绑
  734. RETCODE int32 `json:"retcode" xorm:"RETCODE"` // 返回码
  735. ACCOUNTID int64 `json:"accountid" xorm:"ACCOUNTID"` // 账号ID
  736. CHANNELBUILDTYPE int32 `json:"channelbuildtype" xorm:"CHANNELBUILDTYPE"` // 委托单据类型 0:无 1:建仓 2:平仓
  737. TRADETIME string `json:"tradetime" xorm:"TRADETIME"` // 成交时间
  738. ACCOUNTNAME string `json:"accountname" xorm:"ACCOUNTNAME" form:"accountname"` // 套期主体
  739. ENABLEQTY float64 `json:"enableqty" xorm:"ENABLEQTY"` // 项目可关联手数 = 成交手数 - 关联数量
  740. USERID int64 `json:"-" form:"userid" binding:"required"` // 用户编号
  741. BEGINDATE string `json:"-" form:"begindate"` // 起始日期, 格式:yyyymmdd
  742. ENDDATE string `json:"-" form:"enddate"` // 终止日期, 格式:yyyymmdd
  743. GOODSCODE string `json:"goodscode" xorm:"GOODSCODE" form:"goodscode"` // 合约代码
  744. GOODSNAME string `json:"goodsname" xorm:"GOODSNAME" form:"goodsname"` // 合约名称
  745. }
  746. func (r *InternalUncorrelatedTradeDetail) calc() {
  747. }
  748. func (r *InternalUncorrelatedTradeDetail) buildSql() string {
  749. var sqlId utils.SQLVal = `
  750. SELECT
  751. to_char(ept.TRADETIME, 'yyyy-mm-dd hh24:mi:ss') TRADETIME,
  752. ept.GOODSID,
  753. g.GOODSCODE,
  754. g.GOODSNAME,
  755. ept.BUYORSELL,
  756. ept.TRADEPRICE,
  757. ept.TRADELOT,
  758. ept.RELATEDQTY,
  759. ept.RELATEDLOT,
  760. ept.MIDDLEGOODSQTY,
  761. e.ENUMDICNAME,
  762. to_char(ept.TRADEID) TRADEID,
  763. ua.ACCOUNTNAME,
  764. ta.accountname TAACCOUNTNAME,
  765. ept.ACCOUNTID,
  766. ept.CHANNELBUILDTYPE,
  767. (ept.TRADELOT - ept.RELATEDQTY) ENABLEQTY
  768. FROM ERMCP_PA_TRADELINK ept
  769. LEFT JOIN goods g ON ept.goodsid = g.goodsid
  770. LEFT JOIN taaccount ta ON ta.accountid = ept.accountid
  771. LEFT JOIN useraccount ua ON ta.RELATEDUSERID = ua.userid
  772. LEFT JOIN enumdicitem e ON e.enumitemname = g.goodunitid AND e.enumdiccode = 'goodsunit'
  773. WHERE ept.tradelot > ept.relatedlot
  774. and ept.areauserid in
  775. (select u1.userid
  776. FROM useraccount u1
  777. start with u1.userid = %v
  778. connect by prior u1.userid = u1.parentuserid)
  779. `
  780. sqlId.FormatParam(r.USERID)
  781. if r.BEGINDATE != "" {
  782. sqlId.JoinFormat(" and to_char(ept.tradetime, 'yyyymmdd') >= '%v", r.BEGINDATE)
  783. }
  784. if r.ENDDATE != "" {
  785. sqlId.JoinFormat(" and to_char(ept.tradetime, 'yyyymmdd') <= '%v", r.ENDDATE)
  786. }
  787. sqlId.AndLike("g.goodscode", r.GOODSCODE)
  788. sqlId.AndLike("g.goodsname", r.GOODSNAME)
  789. sqlId.AndEx("ept.TRADEID", r.TRADEID, r.TRADEID != "")
  790. sqlId.AndEx("ept.BUYORSELL", r.BUYORSELL, r.BUYORSELL != -1)
  791. sqlId.AndLikes2("ta.accountname", "ta.accountid", r.ACCOUNTNAME)
  792. sqlId.OrderByDesc("ept.tradetime")
  793. return sqlId.String()
  794. }
  795. // GetDataEx 从数据库中查询数据
  796. func (r *InternalUncorrelatedTradeDetail) GetDataEx() (interface{}, error) {
  797. e := db.GetEngine()
  798. s := e.SQL(r.buildSql())
  799. sData := make([]InternalUncorrelatedTradeDetail, 0)
  800. if err := s.Find(&sData); err != nil {
  801. return nil, err
  802. }
  803. for i := range sData {
  804. sData[i].calc()
  805. }
  806. return sData, nil
  807. }
  808. // InternalEnableTradeDetail 内部成交单可关联项目
  809. type InternalEnableTradeDetail struct {
  810. HEDGEDITEMNUM string `json:"hedgeditemnum" xorm:"HEDGEDITEMNUM"` // 项目编号
  811. Deliverygoodsid int32 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID(SEQ_DELIVERYGOODS)
  812. Deliverygoodscode string `json:"deliverygoodscode" xorm:"DELIVERYGOODSCODE"` // 现货品种代码
  813. Deliverygoodsname string `json:"deliverygoodsname" xorm:"DELIVERYGOODSNAME"` // 现货品种名称
  814. Wrstandardid int64 `json:"wrstandardid" xorm:"WRSTANDARDID"` // 现货品类ID(SEQ_WRSTANDARD)
  815. Wrstandardcode string `json:"wrstandardcode" xorm:"WRSTANDARDCODE"` // 现货品类代码
  816. Wrstandardname string `json:"wrstandardname" xorm:"WRSTANDARDNAME"` // 现货品类名称
  817. UNEXESPOTQTY float64 `json:"unexespotqty" xorm:"UNEXESPOTQTY"` // 未执行现货量
  818. UNEXEHEDGEQTY float64 `json:"unexehedgeqty" xorm:"UNEXEHEDGEQTY"` // 未执行套期量 = 未执行现货量*折算系数* (1/(1+增值税)) * 套期比例(项目上)
  819. FUTUREHEDGEQTY float64 `json:"futurehedgeqty" xorm:"FUTUREHEDGEQTY"` // [已关联数量]期货持仓套期量
  820. AREAUSERID int64 `json:"areauserid" xorm:"AREAUSERID" form:"areauserid" binding:"required"` // 企业ID
  821. GOODSID int64 `form:"goodsid" binding:"required"` // 期货合约ID
  822. }
  823. func (r *InternalEnableTradeDetail) calc() {
  824. }
  825. func (r *InternalEnableTradeDetail) buildSql() string {
  826. var sqlId utils.SQLVal = `
  827. SELECT
  828. hi.HEDGEDITEMNUM,
  829. dg.DELIVERYGOODSID,
  830. dg.DELIVERYGOODSCODE,
  831. dg.DELIVERYGOODSNAME,
  832. wr.WRSTANDARDID,
  833. wr.WRSTANDARDCODE,
  834. wr.WRSTANDARDNAME,
  835. t.UNEXESPOTQTY,
  836. t.UNEXEHEDGEQTY,
  837. t.FUTUREHEDGEQTY
  838. FROM ERMCP2_HIMiddleGoods t
  839. LEFT JOIN ERMCP2_HedgedItem hi ON hi.HEDGEDITEMID = t.HEDGEDITEMID
  840. LEFT JOIN DeliveryGoods dg ON dg.DELIVERYGOODSID = t.DELIVERYGOODSID
  841. LEFT JOIN WRStandard wr ON wr.WRStandardID = t.WRStandardID
  842. LEFT JOIN ERMS_MiddleGoods mg ON mg.MIDDLEGOODSID = t.MIDDLEGOODSID
  843. LEFT JOIN ERMCP_GGConvertConfig gc ON gc.destgoodsgroupid = mg.goodsgroupid
  844. LEFT JOIN Goods g ON g.GOODSGROUPID = gc.SRCGOODSGROUPID
  845. WHERE 1 = 1
  846. `
  847. sqlId.And("t.AREAUSERID", r.AREAUSERID)
  848. sqlId.And("g.GOODSID", r.GOODSID)
  849. return sqlId.String()
  850. }
  851. // GetDataEx 从数据库中查询数据
  852. func (r *InternalEnableTradeDetail) GetDataEx() (interface{}, error) {
  853. e := db.GetEngine()
  854. s := e.SQL(r.buildSql())
  855. sData := make([]InternalEnableTradeDetail, 0)
  856. if err := s.Find(&sData); err != nil {
  857. return nil, err
  858. }
  859. for i := range sData {
  860. sData[i].calc()
  861. }
  862. return sData, nil
  863. }
  864. // Ermcp8HedgeditemReport 套期项目报表
  865. type Ermcp8HedgeditemReport struct {
  866. HEDGEDTYPE int32 `json:"hedgedtype" xorm:"HEDGEDTYPE" form:"hedgedtype"` // 套期类型 - 1:采购计划项目 2:销售计划项目 3:现货贸易项目 4:库存存货项目 5:定价采购合同项目
  867. TRADEUSERID int64 `json:"tradeuserid" xorm:"TRADEUSERID"` // 交易用户ID
  868. AREAUSERID int64 `json:"areauserid" xorm:"AREAUSERID"` // 企业ID
  869. HEDGEDITEMSTATUS int32 `json:"hedgeditemstatus" xorm:"HEDGEDITEMSTATUS" form:"hedgeditemstatus"` // 项目状态 - 2:执行中 3:正常完结 4:审核拒绝 5:异常完结 6:已撤回
  870. HEDGEDITEMNUM string `json:"hedgeditemnum" xorm:"HEDGEDITEMNUM" form:"hedgeditemnum"` // 项目编号,模糊查询
  871. WRSTANDARDID int64 `json:"wrstandardid" xorm:"WRSTANDARDID" form:"wrstandardid"` // 现货商品ID
  872. Wrstandardcode string `json:"wrstandardcode" xorm:"WRSTANDARDCODE"` // 现货品类代码
  873. Wrstandardname string `json:"wrstandardname" xorm:"WRSTANDARDNAME"` // [现货商品]现货品类名称
  874. HEDGEQTY float64 `json:"hedgeqty" xorm:"HEDGEQTY"` // [套期数量]套期现货量
  875. ORIAVGPRICE float64 `json:"oriavgprice" xorm:"ORIAVGPRICE"` // [期初价]期初市场均价 = 套期市价总额 / 套期现货量
  876. HEDGEAMOUNT float64 `json:"hedgeamount" xorm:"HEDGEAMOUNT"` // [套期现货金额]套期市价总额
  877. EXEQTY float64 `json:"exeqty" xorm:"EXEQTY"` // [执行数量]执行现货量
  878. EXEAVGPRICE float64 `json:"exeavgprice" xorm:"EXEAVGPRICE"` // [执行价]执行市场均价= 执行市价总额 / 执行现货量
  879. EXEAMOUNT float64 `json:"exeamount" xorm:"EXEAMOUNT"` // [执行现货金额]执行市价总额
  880. FUTUREHEDGEPL float64 `json:"futurehedgepl" xorm:"FUTUREHEDGEPL"` // 期货实际损益
  881. FUTUREHEDGEPLCHANGE float64 `json:"futurehedgeplchange" xorm:"FUTUREHEDGEPLCHANGE"` // 期货实际变动 = 期货实际损益 - 期初期货实际损益
  882. FUTUREPL float64 `json:"futurepl" xorm:"FUTUREPL"` // 期货套期损益
  883. FUTUREPLCHANGE float64 `json:"futureplchange" xorm:"FUTUREPLCHANGE"` // 期货套期变动 = 期货套期损益 - 期初期货套期损益
  884. SPOTHEDGEPL float64 `json:"spothedgepl" xorm:"SPOTHEDGEPL"` // 现货实际损益 =(执行市场均价-期初市场均价)*执行现货量 * 方向(销售计划 为 -1, 其它为1)
  885. SPOTHEDGEPLCHANGE float64 `json:"spothedgeplchange" xorm:"SPOTHEDGEPLCHANGE"` // 现货实际变动 = 现货实际损益 - 期初现货实际损益
  886. SPOTPL float64 `json:"spotpl" xorm:"SPOTPL"` // 现货套期损益 = 现货实际损益 + 现货浮动损益
  887. SPOTPLCHANGE float64 `json:"spotplchange" xorm:"SPOTPLCHANGE"` // 现货套期变动 = 现货套期损益 - 期初现货套期损益
  888. UNEXEQTY float64 `json:"unexeqty" xorm:"UNEXEQTY"` // 未执行现货量 = 套期现货量 - 执行现货量
  889. CURPRICE float64 `json:"curprice" xorm:"CURPRICE"` // [当日现货市场价]当前市场价
  890. PLANSTARTDATE time.Time `json:"planstartdate" xorm:"PLANSTARTDATE"` // 计划开始日期
  891. PLANENDDATE time.Time `json:"planenddate" xorm:"PLANENDDATE"` // 计划结束日期
  892. ORISPOTHEDGEPL float64 `json:"orispothedgepl" xorm:"ORISPOTHEDGEPL"` // 期初现货实际损益
  893. ORIFUTUREHEDGEPL float64 `json:"orifuturehedgepl" xorm:"ORIFUTUREHEDGEPL"` // 期初期货实际损益
  894. ORISPOTPL float64 `json:"orispotpl" xorm:"ORISPOTPL"` // 期初现货套期损益
  895. ORIFUTUREPL float64 `json:"orifuturepl" xorm:"ORIFUTUREPL"` // 期初期货套期损益
  896. EnumdicName string `json:"enumdicname" xorm:"ENUMDICNAME"` // 单位
  897. AccountName string `json:"accountName" xorm:"ACCOUNTNAME"` // 套期主体
  898. USERID int64 `form:"userid" binding:"required"` // 用户ID
  899. CYCLETYPE int32 `form:"cycletype"` // 周期类型 - 0:日 1:月 2:季 3:年 4:周 5:全报表【原值】
  900. CYCLETIME string `form:"cycletime" binding:"required"` // 周期时间 日(YYYYMMDD) 月(YYYYMM) 季(YYYYQ) 年(YYYY) 周(YYYYMMDD周内任意一天) 全(0)【原值】
  901. }
  902. func (r *Ermcp8HedgeditemReport) calc() {
  903. }
  904. func (r *Ermcp8HedgeditemReport) buildSql() string {
  905. if r.CYCLETYPE == 0 {
  906. // 日
  907. return r.buildReckonSql()
  908. } else {
  909. // 周、月
  910. return r.buildReportSql()
  911. }
  912. }
  913. func (r *Ermcp8HedgeditemReport) buildReckonSql() string {
  914. var sqlId utils.SQLVal = `
  915. SELECT
  916. t.HEDGEDTYPE,
  917. t.TRADEUSERID,
  918. t.AREAUSERID,
  919. t.HEDGEDITEMSTATUS,
  920. t.HEDGEDITEMNUM,
  921. wr.WRSTANDARDID,
  922. wr.WRSTANDARDCODE,
  923. wr.WRSTANDARDNAME,
  924. t.HEDGEQTY,
  925. t.ORIAVGPRICE,
  926. t.HEDGEAMOUNT,
  927. t.EXEQTY,
  928. t.EXEAVGPRICE,
  929. t.EXEAMOUNT,
  930. t.FUTUREHEDGEPL,
  931. (t.FUTUREHEDGEPL - t.ORIFUTUREHEDGEPL) FUTUREHEDGEPLCHANGE,
  932. t.FUTUREPL,
  933. (t.FUTUREPL - t.ORIFUTUREPL) FUTUREPLCHANGE,
  934. t.SPOTHEDGEPL,
  935. (t.SPOTHEDGEPL - t.ORISPOTHEDGEPL) SPOTHEDGEPLCHANGE,
  936. t.SPOTPL,
  937. (t.SPOTPL - t.ORISPOTPL) SPOTPLCHANGE,
  938. t.UNEXEQTY,
  939. t.CURPRICE,
  940. t.PLANSTARTDATE,
  941. t.PLANENDDATE,
  942. e.ENUMDICNAME,
  943. u.ACCOUNTNAME
  944. FROM Reckon_ERMCP2_HedgedItem t
  945. LEFT JOIN WRStandard wr ON wr.WRStandardID = t.WRStandardID
  946. LEFT JOIN WRStandard wr ON wr.wrstandardid = t.wrstandardid
  947. LEFT JOIN enumdicitem e on wr.unitid=e.enumitemname and e.enumdiccode='goodsunit'
  948. LEFT JOIN useraccount u ON u.userid = t.tradeuserid
  949. WHERE (t.TRADEUSERID = %v OR t.AREAUSERID = %v)
  950. `
  951. sqlId.FormatParam(r.USERID, r.USERID)
  952. sqlId.And("t.RECKONDATE", r.CYCLETIME)
  953. sqlId.AndEx("t.HEDGEDTYPE", r.HEDGEDTYPE, r.HEDGEDTYPE > 0)
  954. sqlId.AndEx("t.HEDGEDITEMSTATUS", r.HEDGEDITEMSTATUS, r.HEDGEDITEMSTATUS > 0)
  955. sqlId.AndLike("t.HEDGEDITEMNUM", r.HEDGEDITEMNUM)
  956. sqlId.AndEx("t.WRSTANDARDID", r.WRSTANDARDID, r.WRSTANDARDID > 0)
  957. return sqlId.String()
  958. }
  959. func (r *Ermcp8HedgeditemReport) buildReportSql() string {
  960. var sqlId utils.SQLVal = `
  961. SELECT
  962. t.HEDGEDTYPE,
  963. t.TRADEUSERID,
  964. t.AREAUSERID,
  965. t.HEDGEDITEMSTATUS,
  966. t.HEDGEDITEMNUM,
  967. wr.WRSTANDARDID,
  968. wr.WRSTANDARDCODE,
  969. wr.WRSTANDARDNAME,
  970. t.HEDGEQTY,
  971. t.ORIAVGPRICE,
  972. t.HEDGEAMOUNT,
  973. t.EXEQTY,
  974. t.EXEAVGPRICE,
  975. t.EXEAMOUNT,
  976. t.FUTUREHEDGEPL,
  977. (t.FUTUREHEDGEPL - t.ORIFUTUREHEDGEPL) FUTUREHEDGEPLCHANGE,
  978. t.FUTUREPL,
  979. (t.FUTUREPL - t.ORIFUTUREPL) FUTUREPLCHANGE,
  980. t.SPOTHEDGEPL,
  981. (t.SPOTHEDGEPL - t.ORISPOTHEDGEPL) SPOTHEDGEPLCHANGE,
  982. t.SPOTPL,
  983. (t.SPOTPL - t.ORISPOTPL) SPOTPLCHANGE,
  984. t.UNEXEQTY,
  985. t.CURPRICE,
  986. t.PLANSTARTDATE,
  987. t.PLANENDDATE,
  988. e.ENUMDICNAME,
  989. u.ACCOUNTNAME
  990. FROM REPORT_ERMCP2_HEDGEDITEM t
  991. LEFT JOIN WRStandard wr ON wr.WRStandardID = t.WRStandardID
  992. LEFT JOIN WRStandard wr ON wr.wrstandardid = t.wrstandardid
  993. LEFT JOIN enumdicitem e on wr.unitid=e.enumitemname and e.enumdiccode='goodsunit'
  994. LEFT JOIN useraccount u ON u.userid = t.tradeuserid
  995. WHERE (t.TRADEUSERID = %v OR t.AREAUSERID = %v)
  996. `
  997. sqlId.FormatParam(r.USERID, r.USERID)
  998. sqlId.And("t.CYCLETIME", r.CYCLETIME)
  999. sqlId.AndEx("t.HEDGEDTYPE", r.HEDGEDTYPE, r.HEDGEDTYPE > 0)
  1000. sqlId.AndEx("t.HEDGEDITEMSTATUS", r.HEDGEDITEMSTATUS, r.HEDGEDITEMSTATUS > 0)
  1001. sqlId.AndLike("t.HEDGEDITEMNUM", r.HEDGEDITEMNUM)
  1002. sqlId.AndEx("t.WRSTANDARDID", r.WRSTANDARDID, r.WRSTANDARDID > 0)
  1003. return sqlId.String()
  1004. }
  1005. // GetDataEx 从数据库中查询数据
  1006. func (r *Ermcp8HedgeditemReport) GetDataEx() (interface{}, error) {
  1007. e := db.GetEngine()
  1008. s := e.SQL(r.buildSql())
  1009. sData := make([]InternalEnableTradeDetail, 0)
  1010. if err := s.Find(&sData); err != nil {
  1011. return nil, err
  1012. }
  1013. for i := range sData {
  1014. sData[i].calc()
  1015. }
  1016. return sData, nil
  1017. }
  1018. // 查询现货合同
  1019. type QrySpotContractExReq struct {
  1020. USERID int64 `form:"userid" binding:"required"` // 用户ID
  1021. PRICETYPE int32 `form:"pricetype"` // 定价类型 - 1:一口价 2:点价 3:暂定价
  1022. CONTRACTNO string `form:"contractno"` // 合同编号, 模拟查询
  1023. CUSTOMERNAME string `form:"customername"` // 对手方, 模拟查询
  1024. CONTRACTTYPE int32 `form:"contracttype"` // 合同类型 - 1:采购 -1:销售
  1025. }
  1026. // ErmcpSpotContractModelEx 现货合同结构(对应现货合同菜单)
  1027. type ErmcpSpotContractModelEx struct {
  1028. SPOTCONTRACTID string `json:"spotcontractid" xorm:"SPOTCONTRACTID"` // 现货合同ID(602+Unix秒时间戳(10位)+xxxxxx)
  1029. CONTRACTNO string `json:"contractno" xorm:"CONTRACTNO"` // [合同编号]现货合同编号
  1030. CONTRACTTYPE int32 `json:"contracttype" xorm:"CONTRACTTYPE"` // [合同类型]现货合同类型 - 1:采购 -1:销售
  1031. USERID int64 `json:"userid" xorm:"USERID"` // 机构ID
  1032. BUYUSERID int64 `json:"buyuserid" xorm:"BUYUSERID"` // 采购方ID
  1033. BUYUSERName string `json:"buyusername" xorm:"BUYUSERName"` // 采购方名称
  1034. SELLUSERID int64 `json:"selluserid" xorm:"SELLUSERID"` // 销售方ID
  1035. SELLUSERNAME string `json:"sellusername" xorm:"SELLUSERNAME"` // 销售方名称
  1036. DELIVERYGOODSID int32 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID
  1037. WRSTANDARDID int32 `json:"wrstandardid" xorm:"wrstandardid"` // 现货商品ID
  1038. WRSTANDARDNAME string `json:"wrstandardname" xorm:"WRSTANDARDNAME"` // [现货商品]现货商品名称
  1039. WRSTANDARDCODE string `json:"wrstandardcode" xorm:"WRSTANDARDCODE"` // 现货商品代码
  1040. DELIVERYGOODSCODE string `json:"deliverygoodscode" xorm:"DELIVERYGOODSCODE"` // 现货品种代码
  1041. DELIVERYGOODSNAME string `json:"deliverygoodsname" xorm:"DELIVERYGOODSNAME"` // 现货品种名称
  1042. PRODUCTTYPE int32 `json:"producttype" xorm:"PRODUCTTYPE"` // 产品类型 - 1:标准仓单 2:等标 3:非标
  1043. CONVERTFACTOR float64 `json:"convertfactor" xorm:"CONVERTFACTOR"` // 标仓系数
  1044. SPOTGOODSDESC string `json:"spotgoodsdesc" xorm:"SPOTGOODSDESC"` // 商品型号
  1045. PRICETYPE int32 `json:"pricetype" xorm:"PRICETYPE"` // 定价类型 - 1:一口价 2:点价 3:暂定价
  1046. QTY float64 `json:"qty" xorm:"QTY"` // [合同数量]数量
  1047. PRICE float64 `json:"price" xorm:"PRICE"` // 价格\暂定价 [1:一口价、3:暂定价]
  1048. AMOUNT float64 `json:"amount" xorm:"AMOUNT"` // 金额 [1:一口价、3:暂定价]
  1049. DELIVERYSTARTDATE string `json:"deliverystartdate" xorm:"DELIVERYSTARTDATE"` // 交收期(开始)
  1050. DELIVERYENDDATE string `json:"deliveryenddate" xorm:"DELIVERYENDDATE"` // 交收期(结束)
  1051. GOODSID int32 `json:"goodsid" xorm:"GOODSID"` // 点价合约ID - 0:为现货,其它为期货商品合约ID [2:点价 3:暂定价]
  1052. GOODSCODE string `json:"goodscode" xorm:"GOODSCODE"` // 点价合约代码
  1053. GOODSNAME string `json:"goodsname" xorm:"GOODSNAME"` // 点价商品名称
  1054. PRICEMOVE float64 `json:"pricemove" xorm:"PRICEMOVE"` // 升贴水 [2:点价 3:暂定价]
  1055. STARTDATE string `json:"startdate" xorm:"STARTDATE"` // 点价开始日期 [2:点价 3:暂定价]
  1056. ENDDATE string `json:"enddate" xorm:"ENDDATE"` // 点价结束日期 [2:点价 3:暂定价]
  1057. MARGIN float64 `json:"margin" xorm:"MARGIN"` // 当前保证金
  1058. CONTRACTMARGIN float64 `json:"contractmargin" xorm:"CONTRACTMARGIN"` // 合同保证金
  1059. EnumdicName string `json:"enumdicname" xorm:"ENUMDICNAME"` // 单位名称
  1060. CONTRACCTSTATUS int32 `json:"contracctstatus" xorm:"CONTRACTSTATUS"` // 合同状态 - 0:未提交 1:待审核 2:执行中 3:正常完结 4:审核拒绝 5:异常完结 6:已撤回
  1061. Remark string `json:"remark" xorm:"Remark"` // 备注
  1062. AUDITREMARK string `json:"auditremark" xorm:"AUDITREMARK"` // 审核意见
  1063. AUDITTIME string `json:"audittime" xorm:"AUDITTIME"` // 审核时间
  1064. CREATETIME string `json:"createtime" xorm:"CREATETIME"` // 创建时间
  1065. UPDATETIME string `json:"updatetime" xorm:"UPDATETIME"` // 更新时间
  1066. SPOTGOODSMODELID int32 `json:"spotgoodsmodelid" xorm:"SPOTGOODSMODELID"` // 现货型号ID
  1067. SPOTGOODSBRANDID int32 `json:"spotgoodsbrandid" xorm:"SPOTGOODSBRANDID"` // 现货品牌ID
  1068. BRANDNAME string `json:"brandname" xorm:"brandname"` // 品牌名称
  1069. MODELNAME string `json:"modelname" xorm:"modelname"` // 型号名称
  1070. ATTACHMENT string `json:"attachment" xorm:"ATTACHMENT"` // 附件
  1071. PRICEDQTY float64 `json:"pricedqty" xorm:"PRICEDQTY"` // 已定价量
  1072. PRICEDAMOUNT float64 `json:"pricedamount" xorm:"PRICEDAMOUNT"` // 已定价金额 = (点价价格+升贴水) * 数量
  1073. SPOTAMOUNT float64 `json:"spotamount" xorm:"SPOTAMOUNT"` // 合同现货金额 [不含升贴水]
  1074. TRADEUSERID int64 `json:"tradeuserid" xorm:"TRADEUSERID"` // 交易用户ID
  1075. CUSTOMERUSERID int64 `json:"customeruserid" xorm:"CUSTOMERUSERID"` // 客户ID
  1076. ISRELATED int32 `json:"isrelated" xorm:"ISRELATED"` // 是否已关联计划项目 - 0:否 1:是
  1077. ISRELATED2 int32 `json:"isrelated2" xorm:"ISRELATED2"` // 是否已关联现货项目 - 0:否 1:是
  1078. ACCOUNTNAME string `json:"accountName" xorm:"ACCOUNTNAME"` // 套期主体
  1079. CUSTOMERNAME string `json:"customername" xorm:"CUSTOMERNAME"` // 对手方
  1080. UNPRICEDQTY float64 `json:"unpricedqty" xorm:"UNPRICEDQTY"` // 未定价量 = 合同数量 - 已定价量
  1081. AVGPRICE float64 `json:"avgprice" xorm:"AVGPRICE"` // 定价均价 = 已定价金额 / 已定价量
  1082. SPOTAVGPRICE float64 `json:"spotavgprice" xorm:"SPOTAVGPRICE"` // 现货均价 = 合同现货金额 / 已定价量
  1083. }
  1084. func (r *ErmcpSpotContractModelEx) buildSql(req QrySpotContractExReq) string {
  1085. str := `
  1086. SELECT to_char(t.SPOTCONTRACTID) SPOTCONTRACTID,
  1087. t.CONTRACTNO,
  1088. t.CONTRACTTYPE,
  1089. t.USERID,
  1090. t.BUYUSERID,
  1091. t.SELLUSERID,
  1092. t.DELIVERYGOODSID,
  1093. t.wrstandardid,
  1094. t.PRODUCTTYPE,
  1095. w.CONVERTFACTOR,
  1096. t.SPOTGOODSDESC,
  1097. t.PRICETYPE,
  1098. t.QTY,
  1099. t.PRICE,
  1100. t.AMOUNT,
  1101. to_char(t.DELIVERYSTARTDATE, 'yyyy-mm-dd hh24:mi:ss') DELIVERYSTARTDATE,
  1102. to_char(t.DELIVERYENDDATE, 'yyyy-mm-dd hh24:mi:ss') DELIVERYENDDATE,
  1103. t.GOODSID,
  1104. t.PRICEMOVE,
  1105. to_char(t.STARTDATE, 'yyyy-mm-dd hh24:mi:ss') STARTDATE,
  1106. to_char(t.ENDDATE, 'yyyy-mm-dd hh24:mi:ss') ENDDATE,
  1107. t.MARGIN,
  1108. t.contractmargin,
  1109. t.remark,
  1110. t.pointdesc,
  1111. t.auditremark,
  1112. to_char(t.contractattachment) attachment,
  1113. t.contractstatus,
  1114. t.SPOTGOODSBRANDID,
  1115. to_char(t.audittime, 'yyyy-mm-dd hh24:mi:ss') audittime,
  1116. to_char(t.createtime, 'yyyy-mm-dd hh24:mi:ss') createtime,
  1117. to_char(t.updatetime, 'yyyy-mm-dd hh24:mi:ss') updatetime,
  1118. g.deliverygoodscode,
  1119. g.deliverygoodsname,
  1120. g2.goodscode,
  1121. g2.goodsname,
  1122. gb.dgfactoryitemvalue brandname,
  1123. w.wrstandardname,
  1124. w.wrstandardcode,
  1125. w.vatrate,
  1126. w.unitid,
  1127. t.tradeuserid,
  1128. t.saleuserid,
  1129. t.meruserid,
  1130. t.currencyid,
  1131. to_char(t.accountid) accountid,
  1132. t.biztype,
  1133. to_char(t.subjectid) subjectid,
  1134. b.subjectname,
  1135. (t.QTY - t.PRICEDQTY) UNPRICEDQTY,
  1136. DECODE(t.PRICEDQTY, 0, 0, t.PRICEDAMOUNT/t.PRICEDQTY) AVGPRICE,
  1137. DECODE(t.PRICEDQTY, 0, 0, t.SPOTAMOUNT/t.PRICEDQTY) SPOTAVGPRICE,
  1138. ua.ACCOUNTNAME,
  1139. uc.ACCOUNTNAME CUSTOMERNAME
  1140. FROM ERMCP_SPOTCONTRACT t
  1141. left join ermcp_pa_areasubject b on t.subjectid=b.subjectid
  1142. left join deliverygoods g
  1143. on t.deliverygoodsid = g.deliverygoodsid
  1144. left join goods g2
  1145. on t.goodsid = g2.goodsid
  1146. left join DGFACTORYITEM gb
  1147. on t.spotgoodsbrandid = gb.dgfactoryitemid
  1148. left join wrstandard w
  1149. on t.wrstandardid = w.wrstandardid
  1150. left join loginaccount l
  1151. on t.applyid = l.loginid
  1152. left join useraccount ua
  1153. on ua.userid = t.tradeuserid
  1154. left join useraccount uc
  1155. on uc.userid = t.CUSTOMERUSERID
  1156. where t.contractstatus = 2 and t.ISRELATED = 0 and t.ISRELATED2 = 0
  1157. and (t.userid = %v or t.tradeuserid = %v)
  1158. `
  1159. // "SELECT to_char(t.SPOTCONTRACTID) SPOTCONTRACTID," +
  1160. // " t.CONTRACTNO," +
  1161. // " t.CONTRACTTYPE," +
  1162. // " t.USERID," +
  1163. // " t.BUYUSERID," +
  1164. // " t.SELLUSERID," +
  1165. // " t.DELIVERYGOODSID," +
  1166. // " t.wrstandardid," +
  1167. // " t.PRODUCTTYPE," +
  1168. // " t.CONVERTFACTOR," +
  1169. // " t.SPOTGOODSDESC," +
  1170. // " t.PRICETYPE," +
  1171. // " t.QTY," +
  1172. // " t.PRICE," +
  1173. // " t.AMOUNT," +
  1174. // " to_char(t.DELIVERYSTARTDATE, 'yyyy-mm-dd hh24:mi:ss') DELIVERYSTARTDATE," +
  1175. // " to_char(t.DELIVERYENDDATE, 'yyyy-mm-dd hh24:mi:ss') DELIVERYENDDATE," +
  1176. // " t.GOODSID," +
  1177. // " t.PRICEMOVE," +
  1178. // " to_char(t.STARTDATE, 'yyyy-mm-dd hh24:mi:ss') STARTDATE," +
  1179. // " to_char(t.ENDDATE, 'yyyy-mm-dd hh24:mi:ss') ENDDATE," +
  1180. // " t.MARGIN," +
  1181. // " t.contractmargin," +
  1182. // " t.remark," +
  1183. // " t.auditremark," +
  1184. // " to_char(t.contractattachment) attachment," +
  1185. // " t.contractstatus," +
  1186. // " t.SPOTGOODSMODELID," +
  1187. // " t.SPOTGOODSBRANDID," +
  1188. // " to_char(t.audittime, 'yyyy-mm-dd hh24:mi:ss') audittime," +
  1189. // " to_char(t.createtime, 'yyyy-mm-dd hh24:mi:ss') createtime," +
  1190. // " to_char(t.updatetime, 'yyyy-mm-dd hh24:mi:ss') updatetime," +
  1191. // " u1.accountname BuyUserName," +
  1192. // " u2.accountname SellUserName," +
  1193. // " g.deliverygoodscode," +
  1194. // " g.deliverygoodsname," +
  1195. // " g2.goodscode," +
  1196. // " g2.goodsname," +
  1197. // " gb.brandname," +
  1198. // " gm.modelname," +
  1199. // " e.Enumdicname," +
  1200. // " w.wrstandardname," +
  1201. // " w.wrstandardcode," +
  1202. // " (t.QTY - t.PRICEDQTY) UNPRICEDQTY," +
  1203. // " DECODE(t.PRICEDQTY, 0, 0, t.PRICEDAMOUNT/t.PRICEDQTY) AVGPRICE," +
  1204. // " DECODE(t.PRICEDQTY, 0, 0, t.SPOTAMOUNT/t.PRICEDQTY) SPOTAVGPRICE," +
  1205. // " ua.ACCOUNTNAME," +
  1206. // " uc.ACCOUNTNAME CUSTOMERNAME" +
  1207. // " FROM ERMCP_SPOTCONTRACT t" +
  1208. // " left join useraccount u1" +
  1209. // " on t.buyuserid = u1.userid" +
  1210. // " left join useraccount u2" +
  1211. // " on t.selluserid = u2.userid" +
  1212. // " left join deliverygoods g" +
  1213. // " on t.deliverygoodsid = g.deliverygoodsid" +
  1214. // " left join goods g2" +
  1215. // " on t.goodsid = g2.goodsid" +
  1216. // " left join spotgoodsbrand gb on t.spotgoodsbrandid=gb.brandid" +
  1217. // " left join spotgoodsmodel gm on t.spotgoodsmodelid=gm.modelid" +
  1218. // " left join wrstandard w" +
  1219. // " on t.wrstandardid = w.wrstandardid" +
  1220. // " left join enumdicitem e" +
  1221. // " on w.unitid = e.enumitemname" +
  1222. // " and e.enumdiccode = 'goodsunit'" +
  1223. str = fmt.Sprintf(str, req.USERID, req.USERID)
  1224. if req.PRICETYPE > 0 {
  1225. str += " and t.PRICETYPE = %v"
  1226. str = fmt.Sprintf(str, req.PRICETYPE)
  1227. }
  1228. if len(req.CONTRACTNO) > 0 {
  1229. str += " and t.CONTRACTNO like '%%%s%%'"
  1230. str = fmt.Sprintf(str, req.CONTRACTNO)
  1231. }
  1232. if len(req.CUSTOMERNAME) > 0 {
  1233. str += " and uc.ACCOUNTNAME like '%%%s%%'"
  1234. str = fmt.Sprintf(str, req.CUSTOMERNAME)
  1235. }
  1236. if req.CONTRACTTYPE > 0 {
  1237. str += " and t.CONTRACTTYPE = %v"
  1238. str = fmt.Sprintf(str, req.CONTRACTTYPE)
  1239. }
  1240. str += " order by t.audittime desc"
  1241. return str
  1242. }
  1243. // GetData 从数据库中查询现货合同
  1244. func (r *ErmcpSpotContractModelEx) GetData(req QrySpotContractExReq) ([]ErmcpSpotContractModelEx, error) {
  1245. sData := make([]ErmcpSpotContractModelEx, 0)
  1246. e := db.GetEngine()
  1247. s := e.SQL(r.buildSql(req))
  1248. if err := s.Find(&sData); err != nil {
  1249. logger.GetLogger().Errorf("ermcp query fail:%v", err)
  1250. return sData, err
  1251. }
  1252. return sData, nil
  1253. }