MTP20_IF/models/ermcp8.go

package models

import (
	"mtp2_if/db"
	"mtp2_if/utils"
	"time"
)

// Ermcp2hedgeditem 被套期项目表
type Ermcp2hedgeditem struct {
	Hedgeditemid        string    `json:"hedgeditemid"  xorm:"HEDGEDITEMID"`                                 // 被套期项目ID(624+Unix秒时间戳(10位)+xxxxxx)
	Hedgeditemnum       string    `json:"hedgeditemnum"  xorm:"HEDGEDITEMNUM"`                               // 项目编号
	Hedgeditemname      string    `json:"hedgeditemname"  xorm:"HEDGEDITEMNAME"`                             // 项目名称
	Hedgedtype          int32     `json:"hedgedtype"  xorm:"HEDGEDTYPE" form:"hedgedtype"`                   // 套期类型 - 1:采购计划项目 2:销售计划项目 3:现货贸易项目 4:库存存货项目 5:定价采购合同项目
	Planstartdate       time.Time `json:"planstartdate"  xorm:"PLANSTARTDATE"`                               // 计划开始日期
	Planenddate         time.Time `json:"planenddate"  xorm:"PLANENDDATE"`                                   // 计划结束日期
	Hedgerate           float64   `json:"hedgerate"  xorm:"HEDGERATE"`                                       // 套保比率
	Tradeuserid         int64     `json:"tradeuserid"  xorm:"TRADEUSERID"`                                   // 交易用户ID
	Areauserid          int64     `json:"areauserid"  xorm:"AREAUSERID"`                                     // 企业ID
	Hedgeditemstatus    int32     `json:"hedgeditemstatus"  xorm:"HEDGEDITEMSTATUS" form:"hedgeditemstatus"` // 项目状态 - 0:未提交 1:待审核 2:执行中 3:正常完结 4:审核拒绝 5:异常完结 6:已撤回
	Applysrc            int32     `json:"applysrc"  xorm:"APPLYSRC"`                                         // 申请来源 - 1:管理端 2:终端
	Applyid             int64     `json:"applyid"  xorm:"APPLYID"`                                           // 申请人
	Remark              string    `json:"remark"  xorm:"REMARK"`                                             // 备注
	Createtime          time.Time `json:"createtime"  xorm:"CREATETIME"`                                     // 申请时间
	Audittradedate      string    `json:"audittradedate"  xorm:"AUDITTRADEDATE"`                             // 审核交易日(yyyyMMdd)
	Auditid             int64     `json:"auditid"  xorm:"AUDITID"`                                           // 审核人
	Auditsrc            int32     `json:"auditsrc"  xorm:"AUDITSRC"`                                         // 审核来源 - 1:管理端 2:终端
	Audittime           time.Time `json:"audittime"  xorm:"AUDITTIME"`                                       // 审核时间
	Auditremark         string    `json:"auditremark"  xorm:"AUDITREMARK"`                                   // 审核备注
	Deliverygoodsid     int64     `json:"deliverygoodsid"  xorm:"DELIVERYGOODSID"`                           // 现货品种ID
	Wrstandardid        int64     `json:"wrstandardid"  xorm:"WRSTANDARDID"`                                 // 现货商品ID
	Vatrate             float64   `json:"vatrate"  xorm:"VATRATE"`                                           // 增值税
	Hedgeqty            float64   `json:"hedgeqty"  xorm:"HEDGEQTY"`                                         // 套期现货量
	Hedgeamount         float64   `json:"hedgeamount"  xorm:"HEDGEAMOUNT"`                                   // 套期市价总额
	Hedgerestamount     float64   `json:"hedgerestamount"  xorm:"HEDGERESTAMOUNT"`                           // 套期剩余市价总额【现货贸易】
	Hedgecontractamount float64   `json:"hedgecontractamount"  xorm:"HEDGECONTRACTAMOUNT"`                   // 套期定价总额 【定价采购合同】【现货贸易】
	Oriavgprice         float64   `json:"oriavgprice"  xorm:"ORIAVGPRICE"`                                   // 期初市场均价 = 套期市价总额 / 套期现货量
	Exeqty              float64   `json:"exeqty"  xorm:"EXEQTY"`                                             // 执行现货量
	Exeamount           float64   `json:"exeamount"  xorm:"EXEAMOUNT"`                                       // 执行市价总额
	Exerestamount       float64   `json:"exerestamount"  xorm:"EXERESTAMOUNT"`                               // 执行剩余市价总额【现货贸易】
	Exeavgprice         float64   `json:"exeavgprice"  xorm:"EXEAVGPRICE"`                                   // 执行市场均价= 执行市价总额 / 执行现货量
	Execontractamount   float64   `json:"execontractamount"  xorm:"EXECONTRACTAMOUNT"`                       // 执行定价总额
	Curprice            float64   `json:"curprice"  xorm:"CURPRICE"`                                         // 当前市场价
	Unexeqty            float64   `json:"unexeqty"  xorm:"UNEXEQTY"`                                         // 未执行现货量 = 套期现货量 - 执行现货量
	Spothedgepl         float64   `json:"spothedgepl"  xorm:"SPOTHEDGEPL"`                                   // 现货套期损益 =(执行市场均价-期初市场均价)*执行现货量 * 方向(销售计划 为 -1, 其它为1)
	Spotpl              float64   `json:"spotpl"  xorm:"SPOTPL"`                                             // 现货套期损益 = 现货实际损益 + 现货浮动损益
	Futurehedgepl       float64   `json:"futurehedgepl"  xorm:"FUTUREHEDGEPL"`                               // 期货实际损益
	Futurepl            float64   `json:"futurepl"  xorm:"FUTUREPL"`                                         // 期货套期损益
	Hedgesumpl          float64   `json:"hedgesumpl"  xorm:"HEDGESUMPL"`                                     // 套期汇总损益 = 期货汇总损益 + 现货汇总损益
	Spottradepl         float64   `json:"spottradepl"  xorm:"SPOTTRADEPL"`                                   // 现货贸易损益【现货贸易】= 执行合同定价总额 - 套期合同定价总额
	Vatpl               float64   `json:"vatpl"  xorm:"VATPL"`                                               // 增值税损益【现货贸易】= 现货贸易损益 * （增值税率 /（1+增值税率））
	Sumobspl            float64   `json:"sumobspl"  xorm:"SUMOBSPL"`                                         // 汇总绝对损益【现货贸易】=现货贸易损益+增值税损益+期货套期损益
	Spotbookamount      float64   `json:"spotbookamount"  xorm:"SPOTBOOKAMOUNT"`                             // 现货账面总额
	Curstock            float64   `json:"curstock"  xorm:"CURSTOCK"`                                         // 期末库存量 = 采购总量 - 销售总量
	Enddate             time.Time `json:"enddate"  xorm:"ENDDATE"`                                           // 完成日期
	Endtradedate        string    `json:"endtradedate"  xorm:"ENDTRADEDATE"`                                 // 完成交易日
	Updatetime          time.Time `json:"updatetime"  xorm:"UPDATETIME"`                                     // 更新时间
	Orispothedgepl      float64   `json:"orispothedgepl"  xorm:"ORISPOTHEDGEPL"`                             // 期初现货实际损益
	Orifuturehedgepl    float64   `json:"orifuturehedgepl"  xorm:"ORIFUTUREHEDGEPL"`                         // 期初期货实际损益
	Orispotpl           float64   `json:"orispotpl"  xorm:"ORISPOTPL"`                                       // 期初现货套期损益
	Orifuturepl         float64   `json:"orifuturepl"  xorm:"ORIFUTUREPL"`                                   // 期初期货套期损益
	Spotfloatpl         float64   `json:"spotfloatpl"  xorm:"SPOTFLOATPL"`                                   // 现货浮动损益 =(当前市场价 - 期初市场价)*未执行现货量 * 方向(销售计划 为 -1, 其它为1)
	Futurefloatpl       float64   `json:"futurefloatpl"  xorm:"FUTUREFLOATPL"`                               // 期货浮动损益

	SpotHedgePLChange   float64 `json:"spothedgeplchange" xorm:"SPOTHEDGEPLCHANGE"`     // 现货实际损益变动
	SpotPLChange        float64 `json:"spotplchange" xorm:"SPOTPLCHANGE"`               // 现货套期损益变动
	FutureHedgePLChange float64 `json:"futurehedgeplchange" xorm:"FUTUREHEDGEPLCHANGE"` // 期货实际损益变动
	FuturePLChange      float64 `json:"futureplchange" xorm:"FUTUREPLCHANGE"`           // 期货套期损益变动

	Wrstandardname string `json:"wrstandardname" xorm:"'WRSTANDARDNAME'"` // 商品名称
	EnumdicName    string `json:"enumdicname"  xorm:"'ENUMDICNAME'"`      // 单位
	AccountName    string `json:"accountName" xorm:"ACCOUNTNAME"`         // 套期主体

	MiddleGoodsList []Ermcp2himiddlegoods `json:"middlegoodslist"` // 套期商品列表

	USERID int64 `json:"-" form:"userid" binding:"required"` // 用户id, 用于过滤
}

// TableName is ERMCP2_HEDGEDITEM
func (r *Ermcp2hedgeditem) TableName() string {
	return "ERMCP2_HEDGEDITEM"
}

func (r *Ermcp2hedgeditem) calc() {

}

func (r *Ermcp2hedgeditem) buildSql() string {
	var sqlId utils.SQLVal = `
		SELECT 
			to_char(t.HEDGEDITEMID) HEDGEDITEMID,
			t.HEDGEDITEMNUM      ,
			t.HEDGEDITEMNAME     ,
			t.HEDGEDTYPE         ,
			t.PLANSTARTDATE      ,
			t.PLANENDDATE        ,
			t.HEDGERATE          ,
			t.TRADEUSERID        ,
			t.AREAUSERID         ,
			t.HEDGEDITEMSTATUS   ,
			t.APPLYSRC           ,
			t.APPLYID            ,
			t.REMARK             ,
			t.CREATETIME         ,
			t.AUDITTRADEDATE     ,
			t.AUDITID            ,
			t.AUDITSRC           ,
			t.AUDITTIME          ,
			t.AUDITREMARK        ,
			t.DELIVERYGOODSID    ,
			t.WRSTANDARDID       ,
			t.VATRATE            ,
			t.HEDGEQTY           ,
			t.HEDGEAMOUNT        ,
			t.HEDGERESTAMOUNT    ,
			t.HEDGECONTRACTAMOUNT,
			t.ORIAVGPRICE        ,
			t.EXEQTY             ,
			t.EXEAMOUNT          ,
			t.EXERESTAMOUNT      ,
			t.EXEAVGPRICE        ,
			t.EXECONTRACTAMOUNT  ,
			t.CURPRICE           ,
			t.UNEXEQTY           ,
			t.SPOTHEDGEPL        ,
			t.SPOTPL             ,
			t.FUTUREHEDGEPL      ,
			t.FUTUREPL           ,
			t.HEDGESUMPL         ,
			t.SPOTTRADEPL        ,
			t.VATPL              ,
			t.SUMOBSPL           ,
			t.SPOTBOOKAMOUNT     ,
			t.CURSTOCK           ,
			t.ENDDATE            ,
			t.ENDTRADEDATE       ,
			t.UPDATETIME         ,
			t.ORISPOTHEDGEPL     ,
			t.ORIFUTUREHEDGEPL   ,
			t.ORISPOTPL          ,
			t.ORIFUTUREPL        ,
			t.SPOTFLOATPL        ,
			t.FUTUREFLOATPL      ,
			(t.SpotHedgePL - t.OriSpotHedgePL) SPOTHEDGEPLCHANGE,
			(t.SpotPL - t.OriSpotPL) SPOTPLCHANGE,
			(t.FutureHedgePL - t.OriFutureHedgePL) FUTUREHEDGEPLCHANGE,
			(t.FuturePL - t.OriFuturePL) FUTUREPLCHANGE,
			wr.WRSTANDARDNAME,
			e.ENUMDICNAME,
			u.ACCOUNTNAME
		FROM ERMCP2_HedgedItem t
		LEFT JOIN WRStandard wr ON wr.wrstandardid = t.wrstandardid
		LEFT JOIN enumdicitem e on wr.unitid=e.enumitemname and e.enumdiccode='goodsunit'
		LEFT JOIN useraccount u ON u.userid = t.tradeuserid
		WHERE 1 = 1
   			AND %v in (t.AreaUserID, t.TradeUserID)
	`
	sqlId.FormatParam(r.USERID)
	sqlId.AndEx("t.Hedgedtype", r.Hedgedtype, r.Hedgedtype > 0)
	sqlId.AndEx("t.hedgeditemstatus", r.Hedgeditemstatus, r.Hedgeditemstatus > 0)

	return sqlId.String()
}

// GetDataEx 从数据库中查询数据
func (r *Ermcp2hedgeditem) GetDataEx() (interface{}, error) {
	e := db.GetEngine()
	s := e.SQL(r.buildSql())
	sData := make([]Ermcp2hedgeditem, 0)
	if err := s.Find(&sData); err != nil {
		return nil, err
	}
	for i := range sData {
		sData[i].calc()
	}

	if len(sData) > 0 {
		// 获取关联期货品种
		m1 := Ermcp2himiddlegoods{}
		if d1, err := m1.GetDataEx(); err == nil {
			gpLst := d1.([]Ermcp2himiddlegoods)
			for i := range sData {
				sData[i].MiddleGoodsList = append(sData[i].MiddleGoodsList, gpLst...)
			}
		}
	}

	return sData, nil
}

// Ermcp2himiddlegoods 项目套保品种明细
type Ermcp2himiddlegoods struct {
	HEDGEDITEMID     int64     `json:"hedgeditemid"  xorm:"HEDGEDITEMID" binding:"required"`   // 被套期项目ID(624+Unix秒时间戳(10位)+xxxxxx)
	MIDDLEGOODSID    int64     `json:"middlegoodsid"  xorm:"MIDDLEGOODSID" binding:"required"` // 套保品种ID
	DELIVERYGOODSID  int64     `json:"-"  xorm:"DELIVERYGOODSID"`                              // 现货品种ID
	WRSTANDARDID     int64     `json:"-"  xorm:"WRSTANDARDID"`                                 // 现货商品ID
	VATRATE          float64   `json:"-"  xorm:"VATRATE"`                                      // 增值税
	SPOTCONVERTRATIO float64   `json:"-"  xorm:"SPOTCONVERTRATIO"`                             // 折算系数 [现货]
	UNEXESPOTQTY     float64   `json:"-"  xorm:"UNEXESPOTQTY"`                                 // 未执行现货量
	UNEXEHEDGEQTY    float64   `json:"unexehedgeqty"  xorm:"UNEXEHEDGEQTY"`                    // 未执行套期量 = 未执行现货量*折算系数* (1/(1+增值税)) * 套期比例(项目上)
	FUTUREHEDGEQTY   float64   `json:"futurehedgeqty"  xorm:"FUTUREHEDGEQTY"`                  // 期货持仓套期量
	HIEXPSOURE       float64   `json:"hiexpsoure"  xorm:"HIEXPSOURE"`                          // 期现敞口量 = 未执行套期量 + 期货持仓套期量
	TRADEUSERID      int64     `json:"-"  xorm:"TRADEUSERID"`                                  // 交易用户ID
	AREAUSERID       int64     `json:"-"  xorm:"AREAUSERID"`                                   // 企业ID
	CREATETIME       time.Time `json:"-"  xorm:"CREATETIME"`                                   // 创建时间
	UPDATETIME       time.Time `json:"-"  xorm:"UPDATETIME"`                                   // 更新时间

	Middlegoodsname string `json:"middlegoodsname"  xorm:"'MIDDLEGOODSNAME'"` // 套保商品名称
	Middlegoodscode string `json:"middlegoodscode"  xorm:"'MIDDLEGOODSCODE'"` // 套保商品代码
}

// TableName is ERMCP2_HIMIDDLEGOODS
func (r *Ermcp2himiddlegoods) TableName() string {
	return "ERMCP2_HIMIDDLEGOODS"
}

func (r *Ermcp2himiddlegoods) calc() {

}

func (r *Ermcp2himiddlegoods) buildSql() string {
	var sqlId utils.SQLVal = `
		SELECT 
			t.MIDDLEGOODSID,
			t.UNEXEHEDGEQTY,
			t.FUTUREHEDGEQTY,
			t.HIEXPSOURE,
			m.MIDDLEGOODSNAME,
			m.MIDDLEGOODSCODE
		FROM ERMCP2_HIMIDDLEGOODS t 
		LEFT JOIN erms_middlegoods m ON m.middlegoodsid = t.middlegoodsid
		WHERE t.HEDGEDITEMID = %v
	`
	sqlId.FormatParam(r.HEDGEDITEMID)

	return sqlId.String()
}

// GetDataEx 从数据库中查询数据
func (r *Ermcp2himiddlegoods) GetDataEx() (interface{}, error) {
	e := db.GetEngine()
	s := e.SQL(r.buildSql())
	sData := make([]Ermcp2himiddlegoods, 0)
	if err := s.Find(&sData); err != nil {
		return nil, err
	}
	for i := range sData {
		sData[i].calc()
	}
	return sData, nil
}

// Ermcpjrlinkpos 项目期货关联头寸
type Ermcpjrlinkpos struct {
	SPOTCONTRACTID      string    `json:"spotcontractid"  xorm:"SPOTCONTRACTID" form:"hedgeditemid" binding:"required"` // 现货ID [套期项目ID - 金瑞:合同\虚拟合同ID
	GOODSID             int32     `json:"goodsid"  xorm:"GOODSID"`                                                      // 期货合约
	ORDERTYPE           int32     `json:"ordertype"  xorm:"ORDERTYPE"`                                                  // 单据类型[套期工具] - 1:期货单 2:看涨期权单 3:看跌期权单
	EXECUTEPRICE        int64     `json:"executeprice"  xorm:"EXECUTEPRICE"`                                            // 执行价 - 1:期货单 为 0
	OPTIONCODE          string    `json:"optioncode"  xorm:"OPTIONCODE"`                                                // 期权代码
	AREAUSERID          int64     `json:"areauserid"  xorm:"AREAUSERID"`                                                // 所属企业
	TOTALBUYAMOUNT      float64   `json:"totalbuyamount"  xorm:"TOTALBUYAMOUNT"`                                        // 买金额 [期货]
	TOTALBUYQTY         float64   `json:"totalbuyqty"  xorm:"TOTALBUYQTY"`                                              // 买数量
	TOTALSELLAMOUNT     float64   `json:"totalsellamount"  xorm:"TOTALSELLAMOUNT"`                                      // 卖金额 [期货]
	TOTALSELLQTY        float64   `json:"totalsellqty"  xorm:"TOTALSELLQTY"`                                            // 卖数量
	NETQTY              float64   `json:"netqty"  xorm:"NETQTY"`                                                        // 净头寸
	TOTALCHARGE         float64   `json:"totalcharge"  xorm:"TOTALCHARGE"`                                              // 手续费
	TOTALPREMIUM        float64   `json:"totalpremium"  xorm:"TOTALPREMIUM"`                                            // 权利金 [期权]
	CLOSEPL             float64   `json:"closepl"  xorm:"CLOSEPL"`                                                      // 总平仓盈亏 [期货损益]
	UPDATETIME          time.Time `json:"updatetime"  xorm:"UPDATETIME"`                                                // 更新时间
	TOTALBUYHOLDAMOUNT  float64   `json:"totalbuyholdamount"  xorm:"TOTALBUYHOLDAMOUNT"`                                // 买持仓总金额[期货]
	TOTALSELLHOLDAMOUNT float64   `json:"totalsellholdamount"  xorm:"TOTALSELLHOLDAMOUNT"`                              // 卖持仓总金额[期货]
	TODAYFUTURECLOSEPL  float64   `json:"todayfutureclosepl"  xorm:"TODAYFUTURECLOSEPL"`                                // 今日平仓盈亏
	RECKONPL            float64   `json:"reckonpl"  xorm:"RECKONPL"`                                                    // 总盈亏(平仓盈亏 + 结算盈亏 - 手续费)

	Middlegoodsname string  `json:"middlegoodsname" xorm:"'MIDDLEGOODSNAME'"` // 套保商品名称
	Middlegoodscode string  `json:"middlegoodscode" xorm:"'MIDDLEGOODSCODE'"` // 套保商品代码
	FUTUREHEDGEQTY  float64 `json:"futurehedgeqty" xorm:"FUTUREHEDGEQTY"`     // 期货套期量

	AVERAGEPRICE float64 `json:"averageprice" xorm:"AVERAGEPRICE"` // 持仓均价 (TotalBuyHoldAmount - TotalSellHoldAmount) / NetQty
}

// TableName is ERMCP_JR_LINKPOS
func (r *Ermcpjrlinkpos) TableName() string {
	return "ERMCP_JR_LINKPOS"
}

func (r *Ermcpjrlinkpos) calc() {

}

func (r *Ermcpjrlinkpos) buildSql() string {
	var sqlId utils.SQLVal = `
		SELECT 
			to_char(t.SPOTCONTRACTID) SPOTCONTRACTID,
			t.ORDERTYPE,
			t.OPTIONCODE,
			t.CLOSEPL,
			t.NETQTY,
			((t.TotalBuyHoldAmount - t.TotalSellHoldAmount) / NetQty) AVERAGEPRICE,
			mg.middlegoodsname,
			mg.middlegoodscode
		FROM ERMCP_JR_LinkPos t
		LEFT JOIN Goods g ON g.goodsid = t.goodsid
		LEFT JOIN ERMCP_GGConvertConfig gc on gc.srcgoodsgroupid = g.goodsgroupid
		LEFT JOIN ERMS_MiddleGoods mg ON mg.goodsgroupid = gc.destgoodsgroupid
		WHERE mg.areauserid = t.areauserid AND t.SPOTCONTRACTID = %v
		ORDER BY t.OPTIONCODE 
	`
	// 只有期货合约ID(GoodsID)的情况下获取套保商品名称，需要以上的关联
	sqlId.FormatParam(r.SPOTCONTRACTID)

	return sqlId.String()
}

// GetDataEx 从数据库中查询数据
func (r *Ermcpjrlinkpos) GetDataEx() (interface{}, error) {
	e := db.GetEngine()
	s := e.SQL(r.buildSql())
	sData := make([]Ermcpjrlinkpos, 0)
	if err := s.Find(&sData); err != nil {
		return nil, err
	}
	for i := range sData {
		sData[i].calc()
	}
	return sData, nil
}

// Ermcp2hedgeditemspot 项目现货明细
type Ermcp2hedgeditemspot struct {
	HEDGEDITEMSPOTID      string    `json:"hedgeditemspotid"  xorm:"HEDGEDITEMSPOTID"`                                // 现货明细ID(625+Unix秒时间戳(10位)+xxxxxx)
	HEDGEDITEMID          string    `json:"hedgeditemid"  xorm:"HEDGEDITEMID" form:"hedgeditemid" binding:"required"` // 被套期项目ID
	HEDGEDTYPE            int32     `json:"hedgedtype"  xorm:"HEDGEDTYPE"`                                            // 套期类型[计划类型] - 1:采购计划项目 2:销售计划项目 3:现货贸易项目 4:库存存货项目 5:定价采购合同项目
	SPOTTYPE              int32     `json:"spottype"  xorm:"SPOTTYPE"`                                                // 现货类型 - 1:采购计划 2:销售计划 3:采购合同 4:销售合同 5:库存存货
	RELATEDTYPE           int32     `json:"relatedtype"  xorm:"RELATEDTYPE"`                                          // 关联类型 - 1:套期关联 2:执行关联
	RELATEDHEDGEPLANID    int64     `json:"relatedhedgeplanid"  xorm:"RELATEDHEDGEPLANID"`                            // 关联计划ID 【1:采购计划 2:销售计划】
	RELATEDSPOTCONTRACTID int64     `json:"relatedspotcontractid"  xorm:"RELATEDSPOTCONTRACTID"`                      // 关联合同ID 【3:采购合同 4:销售合同】
	CUSTOMERUSERID        int64     `json:"customeruserid"  xorm:"CUSTOMERUSERID"`                                    // 对手方 【3:采购合同 4:销售合同】
	DELIVERYGOODSID       int64     `json:"deliverygoodsid"  xorm:"DELIVERYGOODSID"`                                  // 现货品种ID
	WRSTANDARDID          int64     `json:"wrstandardid"  xorm:"WRSTANDARDID"`                                        // 现货商品ID
	SPOTGOODSBRANDID      int32     `json:"spotgoodsbrandid"  xorm:"SPOTGOODSBRANDID"`                                // 现货品牌ID -  存“DGFactoryItem”表"DGFactoryItemID" = 2
	RELATEDQTY            float64   `json:"relatedqty"  xorm:"RELATEDQTY"`                                            // 关联数量[数量]
	ORIAVGPRICE           float64   `json:"oriavgprice"  xorm:"ORIAVGPRICE"`                                          // 期初市场价[当初市场价]
	RELATEDAMOUNT         float64   `json:"relatedamount"  xorm:"RELATEDAMOUNT"`                                      // 市价总额 = 关联数量 * 期初市场价
	SPOTPRICEDAMOUNT      float64   `json:"spotpricedamount"  xorm:"SPOTPRICEDAMOUNT"`                                // 定价总额
	SPOTPRICEDAVGPRICE    float64   `json:"spotpricedavgprice"  xorm:"SPOTPRICEDAVGPRICE"`                            // 现货均价 = 定价总额 / 关联数量
	CREATETIME            time.Time `json:"createtime"  xorm:"CREATETIME"`                                            // 创建时间
	TRADEUSERID           int64     `json:"tradeuserid"  xorm:"TRADEUSERID"`                                          // 交易用户ID
	AREAUSERID            int64     `json:"areauserid"  xorm:"AREAUSERID"`                                            // 企业ID

	Wrstandardname string `json:"wrstandardname" xorm:"'WRSTANDARDNAME'"` // 现货商品
	EnumdicName    string `json:"enumdicname"  xorm:"'ENUMDICNAME'"`      // 单位
	Hedgeplanno    string `json:"hedgeplanno"  xorm:"'HEDGEPLANNO'"`      // 计划编号
}

// TableName is ERMCP2_HEDGEDITEMSPOT
func (r *Ermcp2hedgeditemspot) TableName() string {
	return "ERMCP2_HEDGEDITEMSPOT"
}

func (r *Ermcp2hedgeditemspot) calc() {

}

func (r *Ermcp2hedgeditemspot) buildSql() string {
	var sqlId utils.SQLVal = `
		SELECT 
			to_char(t.hedgeditemspotid) HEDGEDITEMSPOTID,
			to_char(t.hedgeditemid) HEDGEDITEMID,
			t.HEDGEDTYPE,
			wr.WRSTANDARDNAME,
			e.ENUMDICNAME,
			t.RELATEDQTY,
			t.ORIAVGPRICE,
			s.HEDGEPLANNO
		FROM ERMCP2_HEDGEDITEMSPOT t
		LEFT JOIN WRStandard wr ON wr.wrstandardid = t.wrstandardid
		LEFT JOIN enumdicitem e on wr.unitid=e.enumitemname and e.enumdiccode='goodsunit'
		LEFT JOIN ermcp_hedgeplan s ON s.HedgePlanID = t.RELATEDHEDGEPLANID
		WHERE t.HedgedType IN (1,2) AND t.hedgeditemid = %v
		ORDER BY t.createtime
	`
	sqlId.FormatParam(r.HEDGEDITEMID)

	return sqlId.String()
}

// GetDataEx 从数据库中查询数据
func (r *Ermcp2hedgeditemspot) GetDataEx() (interface{}, error) {
	e := db.GetEngine()
	s := e.SQL(r.buildSql())
	sData := make([]Ermcp2hedgeditemspot, 0)
	if err := s.Find(&sData); err != nil {
		return nil, err
	}
	for i := range sData {
		sData[i].calc()
	}
	return sData, nil
}

// Ermcp2hedgeditemspotDetail 现货成交明细
type Ermcp2hedgeditemspotDetail struct {
	HEDGEDITEMSPOTID      string    `json:"hedgeditemspotid"  xorm:"HEDGEDITEMSPOTID"`                                // 现货明细ID(625+Unix秒时间戳(10位)+xxxxxx)
	HEDGEDITEMID          string    `json:"hedgeditemid"  xorm:"HEDGEDITEMID" form:"hedgeditemid" binding:"required"` // 被套期项目ID
	HEDGEDTYPE            int32     `json:"hedgedtype"  xorm:"HEDGEDTYPE"`                                            // 套期类型[计划类型] - 1:采购计划项目 2:销售计划项目 3:现货贸易项目 4:库存存货项目 5:定价采购合同项目
	SPOTTYPE              int32     `json:"spottype"  xorm:"SPOTTYPE"`                                                // 现货类型[合同类型] - 1:采购计划 2:销售计划 3:采购合同 4:销售合同 5:库存存货
	RELATEDTYPE           int32     `json:"relatedtype"  xorm:"RELATEDTYPE"`                                          // 关联类型 - 1:套期关联 2:执行关联
	RELATEDHEDGEPLANID    int64     `json:"relatedhedgeplanid"  xorm:"RELATEDHEDGEPLANID"`                            // 关联计划ID 【1:采购计划 2:销售计划】
	RELATEDSPOTCONTRACTID int64     `json:"relatedspotcontractid"  xorm:"RELATEDSPOTCONTRACTID"`                      // 关联合同ID 【3:采购合同 4:销售合同】
	CUSTOMERUSERID        int64     `json:"customeruserid"  xorm:"CUSTOMERUSERID"`                                    // 对手方 【3:采购合同 4:销售合同】
	DELIVERYGOODSID       int64     `json:"deliverygoodsid"  xorm:"DELIVERYGOODSID"`                                  // 现货品种ID
	WRSTANDARDID          int64     `json:"wrstandardid"  xorm:"WRSTANDARDID"`                                        // 现货商品ID
	SPOTGOODSBRANDID      int32     `json:"spotgoodsbrandid"  xorm:"SPOTGOODSBRANDID"`                                // 现货品牌ID -  存“DGFactoryItem”表"DGFactoryItemID" = 2
	RELATEDQTY            float64   `json:"relatedqty"  xorm:"RELATEDQTY"`                                            // 关联数量[数量]
	ORIAVGPRICE           float64   `json:"oriavgprice"  xorm:"ORIAVGPRICE"`                                          // 期初市场价[当初市场价]
	RELATEDAMOUNT         float64   `json:"relatedamount"  xorm:"RELATEDAMOUNT"`                                      // 市价总额 = 关联数量 * 期初市场价
	SPOTPRICEDAMOUNT      float64   `json:"spotpricedamount"  xorm:"SPOTPRICEDAMOUNT"`                                // 定价总额[金额]
	SPOTPRICEDAVGPRICE    float64   `json:"spotpricedavgprice"  xorm:"SPOTPRICEDAVGPRICE"`                            // 现货均价 = 定价总额 / 关联数量
	CREATETIME            time.Time `json:"createtime"  xorm:"CREATETIME"`                                            // 创建时间
	TRADEUSERID           int64     `json:"tradeuserid"  xorm:"TRADEUSERID"`                                          // 交易用户ID
	AREAUSERID            int64     `json:"areauserid"  xorm:"AREAUSERID"`                                            // 企业ID

	Wrstandardname string `json:"wrstandardname" xorm:"'WRSTANDARDNAME'"` // 现货商品
	EnumdicName    string `json:"enumdicname"  xorm:"'ENUMDICNAME'"`      // 单位
	AccountName    string `json:"accountName" xorm:"ACCOUNTNAME"`         // 对手方
	BRANDNAME      string `json:"brandname"  xorm:"'BRANDNAME'"`          // 品牌
	CONTRACTNO     string `json:"contractno"  xorm:"'CONTRACTNO'"`        // 合同编号
}

func (r *Ermcp2hedgeditemspotDetail) calc() {

}

func (r *Ermcp2hedgeditemspotDetail) buildSql() string {
	var sqlId utils.SQLVal = `
	SELECT 
		to_char(t.hedgeditemspotid) HEDGEDITEMSPOTID,
		to_char(t.hedgeditemid) HEDGEDITEMID,
		t.CREATETIME,
		t.SPOTTYPE,
		u.ACCOUNTNAME,
		wr.WRSTANDARDNAME,
		e.ENUMDICNAME,
		gb.dgfactoryitemvalue BRANDNAME,
		t.RELATEDQTY,
		t.SPOTPRICEDAVGPRICE,
		t.SPOTPRICEDAMOUNT,
		t.ORIAVGPRICE,
		s.CONTRACTNO
	FROM ERMCP2_HEDGEDITEMSPOT t
	LEFT JOIN useraccount u ON u.userid = t.CUSTOMERUSERID
	LEFT JOIN WRStandard wr ON wr.wrstandardid = t.wrstandardid
	LEFT JOIN enumdicitem e on wr.unitid=e.enumitemname and e.enumdiccode='goodsunit'
	LEFT JOIN dgfactoryitem gb ON gb.dgfactoryitemid = t.SPOTGOODSBRANDID
	LEFT JOIN ermcp_spotcontract s on s.spotcontractid = t.RELATEDSPOTCONTRACTID
	WHERE t.HedgedType IN (3,4,5) AND t.hedgeditemid = %v
	ORDER BY t.createtime
	`
	sqlId.FormatParam(r.HEDGEDITEMID)

	return sqlId.String()
}

// GetDataEx 从数据库中查询数据
func (r *Ermcp2hedgeditemspotDetail) GetDataEx() (interface{}, error) {
	e := db.GetEngine()
	s := e.SQL(r.buildSql())
	sData := make([]Ermcp2hedgeditemspotDetail, 0)
	if err := s.Find(&sData); err != nil {
		return nil, err
	}
	for i := range sData {
		sData[i].calc()
	}
	return sData, nil
}

// Ermcppatradelinkdetail 期货成交单关联明细表
type Ermcppatradelinkdetail struct {
	LINKDETAILID   string    `json:"linkdetailid"  xorm:"LINKDETAILID"`                                          // 期货明细ID(614+Unix秒时间戳(10位)+xxxxxx)
	TRADEID        string    `json:"tradeid"  xorm:"TRADEID"`                                                    // [成交单号]内部成交单ID
	BUYORSELL      int32     `json:"buyorsell"  xorm:"BUYORSELL"`                                                // 方向 - 0:买 1:卖
	HEDGEFLAG      int32     `json:"hedgeflag"  xorm:"HEDGEFLAG"`                                                // 投机套保标志 - 0:无 1:投机 2:套保 3:套利 4:套期保值(平安\合同) 5:单边(平安) 6:移仓(平安) 7:错单处理(平安) 8:跨期套利(平安) 9:套期保值(计划) 10:套利(合同)  11:换月(合同)  12:交割(金瑞) 13:被套期项目
	SPOTCONTRACTID int64     `json:"hedgeditemid"  xorm:"SPOTCONTRACTID" form:"hedgeditemid" binding:"required"` // 现货ID[套期项目ID] [13 - 被套期项目ID] [4,10,11 - 现货合同ID]  [9 - 套保计划ID]
	RELATEDLOT     float64   `json:"relatedlot"  xorm:"RELATEDLOT"`                                              // [数量]关联手数
	GOODSID        int32     `json:"goodsid"  xorm:"GOODSID"`                                                    // 商品ID
	GOODSGROUPID   int32     `json:"goodsgroupid"  xorm:"GOODSGROUPID"`                                          // 对冲品种ID[期货合约商品组ID]
	MIDDLEGOODSID  int64     `json:"middlegoodsid"  xorm:"MIDDLEGOODSID"`                                        // 套保品种ID
	RELATEDQTY     float64   `json:"relatedqty"  xorm:"RELATEDQTY"`                                              // 关联数量 = RelatedLot * AgreeUnit * ConvertRatio
	TRADEDATE      string    `json:"tradedate"  xorm:"TRADEDATE"`                                                // 关联交易日(yyyyMMdd)
	RELATEDMODE    int32     `json:"relatedmode"  xorm:"RELATEDMODE"`                                            // 关联方式 - 1:自动关联 2:手动关联 3:解绑关联
	TRADETRADEDATE string    `json:"tradetradedate"  xorm:"TRADETRADEDATE"`                                      // 成交交易日(yyyyMMdd)
	TRADEPRICE     float64   `json:"tradeprice"  xorm:"TRADEPRICE"`                                              // [价格]成交价格
	TRADELOT       int64     `json:"tradelot"  xorm:"TRADELOT"`                                                  // 成交手数
	SALEUSERID     int64     `json:"saleuserid"  xorm:"SALEUSERID"`                                              // 业务员ID
	BIZSUBJECTID   int64     `json:"bizsubjectid"  xorm:"BIZSUBJECTID"`                                          // 归属业务部门ID - SubjectID
	AGREEUNIT      float64   `json:"agreeunit"  xorm:"AGREEUNIT"`                                                // 合约乘数
	CONVERTRATIO   float64   `json:"convertratio"  xorm:"CONVERTRATIO"`                                          // 品种系数
	AREAUSERID     int64     `json:"areauserid"  xorm:"AREAUSERID"`                                              // 所属机构
	CREATORSRC     int32     `json:"creatorsrc"  xorm:"CREATORSRC"`                                              // 创建人来源 - 1:管理端 2:终端 3:交易
	CREATORID      int64     `json:"creatorid"  xorm:"CREATORID"`                                                // 创建人ID
	CREATETIME     time.Time `json:"createtime"  xorm:"CREATETIME"`                                              // 创建时间
	LINKSTATUS     int32     `json:"linkstatus"  xorm:"LINKSTATUS"`                                              // 关联状态 - 1:成功 2:失败 3:解绑
	RETCODE        int32     `json:"retcode"  xorm:"RETCODE"`                                                    // 返回码

	TRADETIME  time.Time `json:"tradetime"  xorm:"TRADETIME"`   // 日期时间
	ORDERTYPE  int32     `json:"ordertype"  xorm:"ORDERTYPE"`   // 单据类型[套期工具] - 1:期货单 2:看涨期权单 3:看跌期权单
	OPTIONCODE string    `json:"optioncode"  xorm:"OPTIONCODE"` // [期货合约]期权代码 [期权]
	AMOUNT     float64   `json:"amount"  xorm:"AMOUNT"`         // 金额 = RelatedLot * TradePrice * AgreeUnit
	NAME       string    `json:"name" xorm:"NAME"`              // 账户名/子账户
}

func (r *Ermcppatradelinkdetail) calc() {

}

func (r *Ermcppatradelinkdetail) buildSql() string {
	var sqlId utils.SQLVal = `
	SELECT 
		p.TRADETIME,
		p.ORDERTYPE,
		p.OPTIONCODE,
		t.BUYORSELL,
		t.TRADEPRICE,
		t.RELATEDLOT,
		(t.RelatedLot * t.TradePrice * t.AgreeUnit) AMOUNT,
		to_char(t.TRADEID) TRADEID,
		(u.ACCOUNTNAME || '/' || to_char(t.ACCOUNTID)) NAME
	FROM ERMCP_PA_TradeLinkDetail t
	LEFT JOIN ERMCP_PA_TradeLink p ON p.TradeID = t.TradeID AND p.BuyorSell = t.BuyorSell
	LEFT JOIN TAACCOUNT ta ON ta.ACCOUNTID = t.ACCOUNTID
	LEFT JOIN USERACCOUNT u on u.userid = ta.relateduserid
	WHERE t.HedgeFlag = 13 AND t.SpotContractID = %v
	ORDER BY p.TradeTime
	`
	sqlId.FormatParam(r.SPOTCONTRACTID)

	return sqlId.String()
}

// GetDataEx 从数据库中查询数据
func (r *Ermcppatradelinkdetail) GetDataEx() (interface{}, error) {
	e := db.GetEngine()
	s := e.SQL(r.buildSql())
	sData := make([]Ermcppatradelinkdetail, 0)
	if err := s.Find(&sData); err != nil {
		return nil, err
	}
	for i := range sData {
		sData[i].calc()
	}
	return sData, nil
}

// InternalUncorrelatedTradeDetail 内部未关联成交单
type InternalUncorrelatedTradeDetail struct {
	LINKDETAILID   string    `json:"linkdetailid"  xorm:"LINKDETAILID"`            // 期货明细ID(614+Unix秒时间戳(10位)+xxxxxx)
	TRADEID        string    `json:"tradeid"  xorm:"TRADEID" form:"tradeid"`       // 成交单号
	BUYORSELL      int32     `json:"buyorsell"  xorm:"BUYORSELL" form:"buyorsell"` // 方向 - 0:买 1:卖
	HEDGEFLAG      int32     `json:"hedgeflag"  xorm:"HEDGEFLAG"`                  // 投机套保标志 - 0:无 1:投机 2:套保 3:套利 4:套期保值(平安\合同) 5:单边(平安) 6:移仓(平安) 7:错单处理(平安) 8:跨期套利(平安) 9:套期保值(计划) 10:套利(合同)  11:换月(合同)  12:交割(金瑞) 13:被套期项目
	SPOTCONTRACTID int64     `json:"hedgeditemid"  xorm:"SPOTCONTRACTID"`          // 现货ID[套期项目ID] [13 - 被套期项目ID] [4,10,11 - 现货合同ID]  [9 - 套保计划ID]
	RELATEDLOT     float64   `json:"relatedlot"  xorm:"RELATEDLOT"`                // [数量]关联手数
	GOODSID        int32     `json:"goodsid"  xorm:"GOODSID"`                      // 商品ID
	GOODSGROUPID   int32     `json:"goodsgroupid"  xorm:"GOODSGROUPID"`            // 对冲品种ID[期货合约商品组ID]
	MIDDLEGOODSID  int64     `json:"middlegoodsid"  xorm:"MIDDLEGOODSID"`          // 套保品种ID
	RELATEDQTY     float64   `json:"relatedqty"  xorm:"RELATEDQTY"`                // [套期商品数量]关联数量 = RelatedLot * AgreeUnit * ConvertRatio
	TRADEDATE      string    `json:"tradedate"  xorm:"TRADEDATE"`                  // 关联交易日(yyyyMMdd)
	RELATEDMODE    int32     `json:"relatedmode"  xorm:"RELATEDMODE"`              // 关联方式 - 1:自动关联 2:手动关联 3:解绑关联
	TRADETRADEDATE string    `json:"tradetradedate"  xorm:"TRADETRADEDATE"`        // 成交交易日(yyyyMMdd)
	TRADEPRICE     float64   `json:"tradeprice"  xorm:"TRADEPRICE"`                // 成交价
	TRADELOT       int64     `json:"tradelot"  xorm:"TRADELOT"`                    // 成交手数
	SALEUSERID     int64     `json:"saleuserid"  xorm:"SALEUSERID"`                // 业务员ID
	BIZSUBJECTID   int64     `json:"bizsubjectid"  xorm:"BIZSUBJECTID"`            // 归属业务部门ID - SubjectID
	AGREEUNIT      float64   `json:"agreeunit"  xorm:"AGREEUNIT"`                  // 合约乘数
	CONVERTRATIO   float64   `json:"convertratio"  xorm:"CONVERTRATIO"`            // 品种系数
	AREAUSERID     int64     `json:"areauserid"  xorm:"AREAUSERID"`                // 所属机构
	CREATORSRC     int32     `json:"creatorsrc"  xorm:"CREATORSRC"`                // 创建人来源 - 1:管理端 2:终端 3:交易
	CREATORID      int64     `json:"creatorid"  xorm:"CREATORID"`                  // 创建人ID
	CREATETIME     time.Time `json:"createtime"  xorm:"CREATETIME"`                // 创建时间
	LINKSTATUS     int32     `json:"linkstatus"  xorm:"LINKSTATUS"`                // 关联状态 - 1:成功 2:失败 3:解绑
	RETCODE        int32     `json:"retcode"  xorm:"RETCODE"`                      // 返回码

	TRADETIME   time.Time `json:"tradetime"  xorm:"TRADETIME"`                       // 成交时间
	ACCOUNTNAME string    `json:"accountname" xorm:"ACCOUNTNAME" form:"accountname"` // 套期主体
	ENABLEQTY   float64   `json:"enableqty" xorm:"ENABLEQTY"`                        // 项目可关联手数 = 成交手数 - 关联数量

	USERID    int64  `form:"userid" binding:"required"`  // 用户编号
	BEGINDATE string `json:"-" form:"begindate"`         // 起始日期, 格式：yyyymmdd
	ENDDATE   string `json:"-" form:"enddate"`           // 终止日期, 格式：yyyymmdd
	GOODSCODE string `json:"goodscode" form:"goodscode"` // 合约代码
	GOODSNAME string `json:"goodsname" form:"goodsname"` // 合约名称
}

func (r *InternalUncorrelatedTradeDetail) calc() {

}

func (r *InternalUncorrelatedTradeDetail) buildSql() string {
	var sqlId utils.SQLVal = `
	SELECT 
		ept.TRADETIME,
		ept.GOODSID,
		g.GOODSCODE,
		g.GOODSNAME,
		ept.BUYORSELL,
		ept.TRADEPRICE,
		ept.TRADELOT,
		ept.RELATEDQTY,
		ept.RELATEDLOT,
		ept.MIDDLEGOODSQTY,
		e.ENUMDICNAME,
		to_char(ept.TRADEID) TRADEID,
		ua.ACCOUNTNAME,
		ta.accountname TAACCOUNTNAME,
		ept.ACCOUNTID,
		(ept.TRADELOT - ept.RELATEDQTY) ENABLEQTY
	FROM ERMCP_PA_TRADELINK ept
	LEFT JOIN goods g ON ept.goodsid = g.goodsid
	LEFT JOIN taaccount ta ON ta.accountid = ept.accountid
	LEFT JOIN useraccount ua ON ta.userid = ua.userid
	LEFT JOIN enumdicitem e ON e.enumitemname = g.goodunitid AND e.enumdiccode = 'goodsunit'
	WHERE ept.tradelot > ept.relatedlot
	and ept.areauserid in
		(select u1.userid
			FROM useraccount u1
			start with u1.userid = %v
			connect by prior u1.userid = u1.parentuserid)
	`

	sqlId.FormatParam(r.USERID)
	if r.BEGINDATE != "" {
		sqlId.JoinFormat(" and to_char(ept.tradetime, 'yyyymmdd') >= '%v'", r.BEGINDATE)
	}
	if r.ENDDATE != "" {
		sqlId.JoinFormat(" and to_char(ept.tradetime, 'yyyymmdd') <= '%v'", r.ENDDATE)
	}
	sqlId.AndLike("g.goodscode", r.GOODSCODE)
	sqlId.AndLike("g.goodsname", r.GOODSNAME)
	sqlId.AndEx("ept.TRADEID", r.TRADEID, r.TRADEID != "")
	sqlId.And("ept.BUYORSELL", r.BUYORSELL)
	sqlId.AndLikes2("ta.accountname", "ta.accountid", r.ACCOUNTNAME)
	sqlId.OrderByDesc("ept.tradetime")

	return sqlId.String()
}

// GetDataEx 从数据库中查询数据
func (r *InternalUncorrelatedTradeDetail) GetDataEx() (interface{}, error) {
	e := db.GetEngine()
	s := e.SQL(r.buildSql())
	sData := make([]InternalUncorrelatedTradeDetail, 0)
	if err := s.Find(&sData); err != nil {
		return nil, err
	}
	for i := range sData {
		sData[i].calc()
	}
	return sData, nil
}