MTP20_IF/models/ermcp3.go

/**
* @Author: zou.yingbin
* @Create  : 2021/4/14 11:11
* @Modify  : 2021/4/14 11:11
 */

package models

import (
	"encoding/json"
	"fmt"
	"mtp2_if/db"
	"mtp2_if/logger"
	"mtp2_if/mtpcache"
	"mtp2_if/utils"
	"strings"
)

// ErmcpDeliveryGoods 现货品种(交割品种)
type ErmcpDeliveryGoods struct {
	DELIVERYGOODSID   int32  `json:"deliverygoodsid"  xorm:"'DELIVERYGOODSID'"`     // 现货品种ID(SEQ_DELIVERYGOODS)
	DELIVERYGOODSCODE string `json:"deliverygoodscode"  xorm:"'DELIVERYGOODSCODE'"` // 现货品种代码
	DELIVERYGOODSNAME string `json:"deliverygoodsname"  xorm:"'DELIVERYGOODSNAME'"` // 现货品种名称
	GOODSUNITID       int32  `json:"goodsunitid"  xorm:"'GOODSUNITID'"`             // 现货品种单位ID
	DELIVERYGOODSTYPE int32  `json:"deliverygoodstype"  xorm:"'DELIVERYGOODSTYPE'"` // 现货品种类型: 1-整装不拆分 2-散装记录明细 3:整装拆分 4:散装不记录明细
	STANDARDQTY       int32  `json:"standardqty"  xorm:"'STANDARDQTY'"`             // 标准数量(库位数量) [标准品特有]
	STANDARDQTYRANGE  int32  `json:"standardqtyrange"  xorm:"'STANDARDQTYRANGE'"`   // 标准数量偏差范围 [标准品特有]
	AUDITFLAG         int32  `json:"auditflag"  xorm:"'AUDITFLAG'"`                 // 交割是否需要审核 - 0:不需要 1:需要审核   默认为0
	ISVALID           int32  `json:"isvalid"  xorm:"'ISVALID'"`                     // 是否有效 - 0:无效 1:有效
	AGREEUNIT         int32  `json:"agreeunit"  xorm:"'AGREEUNIT'"`                 // 合约单位[散货时默认为1， 整装时默认为标准数量]
	QTYDECIMALPLACE   int32  `json:"qtydecimalplace"  xorm:"'QTYDECIMALPLACE'"`     // 成交量小数位
	CATEGORYID        int32  `json:"categoryid"  xorm:"'CATEGORYID'"`               // 类别ID(SEQ_WRCATEGORY)
	DGSTATUS          int32  `json:"dgstatus"  xorm:"'DGSTATUS'"`                   // 品种状态 - 作废 - 0:未激活 1:正常
	AREAUSERID        int64  `json:"areauserid"  xorm:"'AREAUSERID'"`               // 所属机构
	REMARK            string `json:"remark"  xorm:"'REMARK'"`                       // 备注

	EnumdicName string `json:"enumdicname"` // 现货品种单位名称
	ExcludeCfg  int32  `json:"-"`           // 排除已配置的业务类型商品 1-套保 2-套利
}

func (r *ErmcpDeliveryGoods) calc() {
	r.EnumdicName = mtpcache.GetEnumDicitemName(r.GOODSUNITID)
}

func (r *ErmcpDeliveryGoods) buildSql() string {
	var sqlId utils.SQLVal = "SELECT t.DELIVERYGOODSID," +
		"       t.DELIVERYGOODSCODE," +
		"       t.DELIVERYGOODSNAME," +
		"       t.GOODSUNITID," +
		"       t.DELIVERYGOODSTYPE," +
		"       t.STANDARDQTY," +
		"       t.STANDARDQTYRANGE," +
		"       t.AUDITFLAG," +
		"       t.ISVALID," +
		"       t.ISSPLIT," +
		"       t.AGREEUNIT," +
		"       t.QTYDECIMALPLACE," +
		"       t.CATEGORYID," +
		"       t.DGSTATUS," +
		"       t.REMARK," +
		"       t.AREAUSERID" +
		"  FROM DELIVERYGOODS t" +
		" WHERE 1 = 1"
	sqlId.AndEx("t.AREAUSERID", r.AREAUSERID, r.AREAUSERID > 0)
	sqlId.AndEx("t.DELIVERYGOODSID", r.DELIVERYGOODSID, r.DELIVERYGOODSID > 0)
	if r.ExcludeCfg > 0 {
		sqlId.Join(fmt.Sprintf(" and t.deliverygoodsid not in(select distinct deliverygoodsid from ermcp_bizgroupspotgoods where biztype = %v)", r.ExcludeCfg))
	}
	return sqlId.String()
}

// GetDataEx 获取现货商品(交割商品)
func (r *ErmcpDeliveryGoods) GetDataEx() (interface{}, error) {
	return r.GetData()
}

// GetData
func (r *ErmcpDeliveryGoods) GetData() ([]ErmcpDeliveryGoods, error) {
	sData := make([]ErmcpDeliveryGoods, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// ErmcpDGFactoryItem 品种选择项定义表
type ErmcpDGFactoryItem struct {
	DGFACTORYITEMID     int64  `json:"dgfactoryitemid"  xorm:"'DGFACTORYITEMID'"`         // 选择项ID(SEQ_DGFACTORYITEM)
	DELIVERYGOODSID     int32  `json:"deliverygoodsid"  xorm:"'DELIVERYGOODSID'"`         // 现货品种ID
	DGFACTORYITEMTYPEID int64  `json:"dgfactoryitemtypeid"  xorm:"'DGFACTORYITEMTYPEID'"` // 要素项类型
	DGFACTORYITEMVALUE  string `json:"dgfactoryitemvalue"  xorm:"'DGFACTORYITEMVALUE'"`   // 要素项值(类型为仓库时填写仓库名称)
	WAREHOUSEID         int64  `json:"warehouseid"  xorm:"'WAREHOUSEID'"`                 // 仓库ID(类型为仓库时填写)
	ISVALID             int32  `json:"isvalid"  xorm:"'ISVALID'"`                         // 是否有效 - 0:无效 1:有效
	ORDERINDEX          int32  `json:"orderindex"  xorm:"'ORDERINDEX'"`                   // 顺序
	AREAUSERID          int64  `json:"areauserid"  xorm:"'AREAUSERID'"`                   // 用户id
}

func (r *ErmcpDGFactoryItem) buildSql() string {
	var sqlId utils.SQLVal = "SELECT DGFACTORYITEMID," +
		"       t.DELIVERYGOODSID," +
		"       to_char(t.DGFACTORYITEMTYPEID) DGFACTORYITEMTYPEID," +
		"       t.DGFACTORYITEMVALUE," +
		"       to_char(t.WAREHOUSEID) WAREHOUSEID," +
		"       t.ISVALID," +
		"       t.ORDERINDEX," +
		"       g.areauserid" +
		"  FROM DGFACTORYITEM t" +
		"  left join deliverygoods g" +
		"    on t.deliverygoodsid = g.deliverygoodsid" +
		" WHERE t.ISVALID = 1"
	sqlId.AndEx("g.areauserid", r.AREAUSERID, r.AREAUSERID > 0)
	sqlId.AndEx("t.DGFACTORYITEMID", r.DGFACTORYITEMID, r.DGFACTORYITEMID > 0)
	sqlId.AndEx("t.DELIVERYGOODSID", r.DELIVERYGOODSID, r.DELIVERYGOODSID > 0)
	sqlId.AndEx("t.DGFACTORYITEMTYPEID", r.DGFACTORYITEMTYPEID, r.DGFACTORYITEMTYPEID > 0)
	sqlId.AndEx("t.ORDERINDEX", r.ORDERINDEX, r.ORDERINDEX > 0)

	return sqlId.String()
}

// GetDataEx 获取品种选择项定义
func (r *ErmcpDGFactoryItem) GetDataEx() (interface{}, error) {
	return r.GetData()
}

// GetData
func (r *ErmcpDGFactoryItem) GetData() (interface{}, error) {
	sData := make([]ErmcpDGFactoryItem, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	return sData, err
}

// Ermcp3Brand 品牌(从品种选择项定义表中查)
type Ermcp3Brand struct {
	BRANDID         int64  `json:"brandid"`         // 品牌id
	BRANDNAME       string `json:"brandname"`       // 品牌名称
	DELIVERYGOODSID int64  `json:"deliverygoodsid"` // 品种ID
	AREAUSERID      int64  `json:"areauserid"`      // 用户id
}

// GetDataEx
func (r *Ermcp3Brand) GetDataEx() (interface{}, error) {
	return r.GetData()
}

// GetData 获取品牌数据
func (r *Ermcp3Brand) GetData() ([]Ermcp3Brand, error) {
	m := ErmcpDGFactoryItem{
		DELIVERYGOODSID:     int32(r.DELIVERYGOODSID),
		DGFACTORYITEMTYPEID: 2,
		ORDERINDEX:          1,
	}
	sData := make([]Ermcp3Brand, 0)
	if d, err := m.GetDataEx(); err == nil {
		if dgLst, ok := d.([]ErmcpDGFactoryItem); ok {
			for _, val := range dgLst {
				sData = append(sData, Ermcp3Brand{BRANDID: val.DGFACTORYITEMID, AREAUSERID: val.AREAUSERID,
					BRANDNAME: val.DGFACTORYITEMVALUE, DELIVERYGOODSID: int64(val.DELIVERYGOODSID)})
			}
		}
	}
	return sData, nil
}

// ErmcpRelatedGoods 现货品种的关联交易商品
type ErmcpRelatedGoods struct {
	GoodsId         int    `json:"goodsid"  xorm:"'GoodsId'"`                 // 商品id
	GoodsCode       string `json:"goodscode"  xorm:"'GoodsCode'"`             // 商品代码
	GoodsName       string `json:"goodsname"  xorm:"'GoodsName'"`             // 商品名称
	DELIVERYGOODSID int32  `json:"deliverygoodsid"  xorm:"'DELIVERYGOODSID'"` // 品种ID

	AREAUSERID int64 `json:"-"` // 所属机构
}

func (r *ErmcpRelatedGoods) buildSql() string {
	var sqlId utils.SQLVal = "select distinct t.deliverygoodsid, g.goodsid, g.goodscode, g.goodsname" +
		"  from deliverygoods t" +
		" inner join ERMS2_WRSConvertDetail w" +
		"    on t.deliverygoodsid = w.deliverygoodsid" +
		" inner join erms_middlegoods m" +
		"    on w.middlegoodsid = m.middlegoodsid" +
		" inner join ERMCP_GGConvertConfig gc" +
		"    on m.goodsgroupid = gc.destgoodsgroupid" +
		" inner join goods g" +
		"    on gc.srcgoodsgroupid = g.goodsgroupid" +
		" where 1 = 1"
	sqlId.AndEx("t.AREAUSERID", r.AREAUSERID, r.AREAUSERID > 0)
	sqlId.AndEx("t.DELIVERYGOODSID", r.DELIVERYGOODSID, r.DELIVERYGOODSID > 0)
	return sqlId.String()
}

// GetDataEx 获取现货关联交易商品
func (r *ErmcpRelatedGoods) GetDataEx() (interface{}, error) {
	return r.GetData()
}

// GetData 获取现货关联交易商品
func (r *ErmcpRelatedGoods) GetData() ([]ErmcpRelatedGoods, error) {
	sData := make([]ErmcpRelatedGoods, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	return sData, err
}

// ErmcpDeliveryGoodsDetail2 现货商品详情(含转换系数)
type ErmcpDeliveryGoodsDetail2 struct {
	ErmcpDeliveryGoodsDetail
	CONVERTRATIO float64 `json:"convertratio"  xorm:"'CONVERTRATIO'"` // 套保系数(折算系数)
}

// ErmcpDeliveryGoodsDetail 现货商品详情
type ErmcpDeliveryGoodsDetail struct {
	Data   ErmcpDeliveryGoods `json:"data"`   // 现货商品基本信息(交割品种)
	GmList []Ermcp3Wrstandard `json:"gmlist"` // 品类列表(仓单标准)
	GbList []Ermcp3Brand      `json:"gblist"` // 品牌列表
}

func (r *ErmcpDeliveryGoodsDetail) addGmList(lst []Ermcp3Wrstandard) {
	for i := range lst {
		if lst[i].DELIVERYGOODSID == r.Data.DELIVERYGOODSID && lst[i].ISVALID == 1 {
			r.GmList = append(r.GmList, lst[i])
		}
	}
}

func (r *ErmcpDeliveryGoodsDetail) addGbList(lst []Ermcp3Brand) {
	for i := range lst {
		if lst[i].DELIVERYGOODSID == int64(r.Data.DELIVERYGOODSID) {
			r.GbList = append(r.GbList, lst[i])
		}
	}
}

// GetData
func (r *ErmcpDeliveryGoodsDetail) GetData() ([]ErmcpDeliveryGoodsDetail, error) {
	sData := make([]ErmcpDeliveryGoodsDetail, 0)
	m := ErmcpDeliveryGoods{AREAUSERID: r.Data.AREAUSERID, DELIVERYGOODSID: r.Data.DELIVERYGOODSID}
	data, err := m.GetData()
	if err != nil {
		return sData, err
	}
	if data == nil || len(data) == 0 {
		return sData, nil
	}
	// 基本信息
	for i := range data {
		val := ErmcpDeliveryGoodsDetail{Data: data[i],
			GmList: make([]Ermcp3Wrstandard, 0), GbList: make([]Ermcp3Brand, 0),
		}
		sData = append(sData, val)
	}
	//品类/品牌/套保信息
	gm := Ermcp3Wrstandard{AREAUSERID: r.Data.AREAUSERID, DELIVERYGOODSID: r.Data.DELIVERYGOODSID, ISVALID: 1}
	gb := Ermcp3Brand{DELIVERYGOODSID: int64(r.Data.DELIVERYGOODSID)}
	gmLst, _ := gm.GetDataEx()
	gbLst, _ := gb.GetData()

	for i := range sData {
		sData[i].addGmList(gmLst.([]Ermcp3Wrstandard))
		sData[i].addGbList(gbLst)
	}

	return sData, nil
}

// GetDataEx
func (r *ErmcpDeliveryGoodsDetail) GetDataEx() (interface{}, error) {
	return r.GetData()
}

// ErmcpDeliveryGoodsDetailEx 现货商品详情(含套保列表)
type ErmcpDeliveryGoodsDetailEx struct {
	ErmcpDeliveryGoodsDetail
	MgList []Ermcp3MiddleGoodsDetail2 `json:"mgList"` // 套保列表
}

// GetData 获取现货商品详情(含套保信息列表)
func (r *ErmcpDeliveryGoodsDetailEx) GetDataEx() (interface{}, error) {
	sData := make([]ErmcpDeliveryGoodsDetailEx, 0)
	mDg := r.ErmcpDeliveryGoodsDetail
	// 查现货商品列表
	if dgList, err := mDg.GetData(); err == nil {
		for i := range dgList {
			sData = append(sData, ErmcpDeliveryGoodsDetailEx{ErmcpDeliveryGoodsDetail: dgList[i],
				MgList: make([]Ermcp3MiddleGoodsDetail2, 0)})
		}
	}
	if len(sData) == 0 {
		return sData, nil
	}
	// 查转换关系
	mWc := WRSConverTDetail{}
	if wc, err := mWc.GetData(); err == nil {
		// 查套保商品列表
		mMg := Ermcp3MiddleGoodsDetail{}
		mMg.Mg.AREAUSERID = r.Data.AREAUSERID
		if mgLst, err := mMg.GetData(); err == nil {
			for i := range sData {
				sData[i].addMgList(mgLst, wc)
			}
		}
	}

	return sData, nil
}

// addMgList 添加关联的套保信息列表
func (r *ErmcpDeliveryGoodsDetailEx) addMgList(lst []Ermcp3MiddleGoodsDetail, wc []WRSConverTDetail) {
	for i := range wc {
		if r.Data.DELIVERYGOODSID == wc[i].DELIVERYGOODSID {
			for k := range lst {
				if int64(lst[k].Mg.MIDDLEGOODSID) == wc[i].MIDDLEGOODSID {
					val := Ermcp3MiddleGoodsDetail2{Ermcp3MiddleGoodsDetail: lst[k], CONVERTRATIO: wc[i].CONVERTRATIO}
					r.MgList = append(r.MgList, val)
				}
			}
		}
	}
}

// Ermcp3MiddleGoodsDetail2 套保品种详情(含转换系数)
type Ermcp3MiddleGoodsDetail2 struct {
	Ermcp3MiddleGoodsDetail
	CONVERTRATIO float64 `json:"convertratio"  xorm:"'CONVERTRATIO'"` // 套保系数(折算系数)
}

// Ermcp3MiddleGoodsDetail 套保品种详情
type Ermcp3MiddleGoodsDetail struct {
	Mg     ErmcpMiddleGoodsModel `json:"mg"`     // 套保商品信息
	GPList []Ermcp3GoodsGroupEx  `json:"gplist"` // 关联商品组列表
}

// GetData 获取套保品种详情(不含现货列表)
func (r *Ermcp3MiddleGoodsDetail) GetData() ([]Ermcp3MiddleGoodsDetail, error) {
	sData := make([]Ermcp3MiddleGoodsDetail, 0)
	// 查基本信息
	mMg := ErmcpMiddleGoodsModel{AREAUSERID: r.Mg.AREAUSERID, MIDDLEGOODSID: r.Mg.MIDDLEGOODSID, ISVALID: 1}
	if mgLst, err := mMg.GetData2(); err == nil {
		for i := range mgLst {
			sData = append(sData, Ermcp3MiddleGoodsDetail{Mg: mgLst[i], GPList: make([]Ermcp3GoodsGroupEx, 0)})
		}
	}
	if len(sData) == 0 {
		return sData, nil
	}
	bExist := false
	// 查关联期货商品组
	mGp := Ermcp3MiddleGoodsRelateGroup{AREAUSERID: r.Mg.AREAUSERID}
	if gpLst, err := mGp.GetData(); err == nil {
		for i := range sData {
			sData[i].addGoodsGroup(gpLst)
		}
		bExist = len(gpLst) > 0
	}

	if bExist {
		mGoods := Ermcp3GoodsEx{AREAUSERID: r.Mg.AREAUSERID}
		if gLst, err := mGoods.GetData(); err == nil {
			for i := range sData {
				sData[i].addGoods(gLst)
			}
		}
	}

	return sData, nil
}

func (r *Ermcp3MiddleGoodsDetail) addGoodsGroup(gpLst []Ermcp3MiddleGoodsRelateGroup) {
	for i := range gpLst {
		if gpLst[i].MIDDLEGOODSID == r.Mg.MIDDLEGOODSID {
			bExist := false
			for _, v := range r.GPList {
				if v.GOODSGROUPID == gpLst[i].GOODSGROUPID {
					bExist = true
					break
				}
			}
			if !bExist {
				val := Ermcp3GoodsGroupEx{
					GOODSGROUPID:   gpLst[i].GOODSGROUPID,
					MIDDLEGOODSID:  gpLst[i].MIDDLEGOODSID,
					CONVERTRATIO:   gpLst[i].CONVERTRATIO,
					EXEXCHANGECODE: gpLst[i].EXEXCHANGECODE,
					GOODSGROUPNAME: gpLst[i].GOODSGROUPNAME,
					ENUMDICNAME:    gpLst[i].ENUMDICNAME,
					GOODSUNITID:    gpLst[i].GOODSUNITID,
					GList:          make([]Ermcp3Goods, 0),
				}
				r.GPList = append(r.GPList, val)
			}
		}
	}
}

func (r *Ermcp3MiddleGoodsDetail) addGoods(gpLst []Ermcp3GoodsEx) {
	for i := range gpLst {
		if gpLst[i].MIDDLEGOODSID == r.Mg.MIDDLEGOODSID {
			for k := range r.GPList {
				if r.GPList[k].GOODSGROUPID == gpLst[i].GOODSGROUPID {
					r.GPList[k].GList = append(r.GPList[k].GList, Ermcp3Goods{
						GOODSID:        gpLst[i].GOODSID,
						GOODSNAME:      gpLst[i].GOODSNAME,
						GOODSCODE:      gpLst[i].GOODSCODE,
						AGREEUNIT:      gpLst[i].AGREEUNIT,
						EXEXCHANGECODE: gpLst[i].EXEXCHANGECODE,
						ENUMDICNAME:    gpLst[i].ENUMDICNAME,
					})
				}
			}
		}
	}
}

// Ermcp3MiddleGoodsDetailEx 套保品种详情(含现货列表)
type Ermcp3MiddleGoodsDetailEx struct {
	Ermcp3MiddleGoodsDetail
	DgList []ErmcpDeliveryGoodsDetail2 `json:"dglist"` // 关联的现货品种列表
}

func (r *Ermcp3MiddleGoodsDetailEx) addDgList(dglst []ErmcpDeliveryGoodsDetail, wc []WRSConverTDetail) {
	for i := range wc {
		if wc[i].MIDDLEGOODSID == int64(r.Mg.MIDDLEGOODSID) {
			for _, detail := range dglst {
				if wc[i].DELIVERYGOODSID == detail.Data.DELIVERYGOODSID && detail.Data.ISVALID == 1 {
					val := ErmcpDeliveryGoodsDetail2{ErmcpDeliveryGoodsDetail: detail, CONVERTRATIO: wc[i].CONVERTRATIO}
					r.DgList = append(r.DgList, val)
				}
			}
		}
	}
}

// GetDataEx
func (r *Ermcp3MiddleGoodsDetailEx) GetDataEx() (interface{}, error) {
	sData := make([]Ermcp3MiddleGoodsDetailEx, 0)
	// 查套保品种基本信息
	m := r.Ermcp3MiddleGoodsDetail
	if mgLst, err := m.GetData(); err == nil {
		for i := range mgLst {
			sData = append(sData, Ermcp3MiddleGoodsDetailEx{Ermcp3MiddleGoodsDetail: mgLst[i],
				DgList: make([]ErmcpDeliveryGoodsDetail2, 0)})
		}
	}
	// 查转换关系
	mWc := WRSConverTDetail{}
	if wc, err := mWc.GetData(); err == nil {
		// 查现货商品列表
		mDg := ErmcpDeliveryGoodsDetail{}
		mDg.Data.AREAUSERID = r.Mg.AREAUSERID
		if dgLst, err := mDg.GetData(); err == nil {
			for i := range sData {
				sData[i].addDgList(dgLst, wc)
			}
		}
	}
	return sData, nil
}

// Ermcp3MiddleGoodsRelateGroup 套保商品关联的期货商品组
type Ermcp3MiddleGoodsRelateGroup struct {
	MIDDLEGOODSID  uint32  `json:"middlegoodsid"  xorm:"'middlegoodsid'"`   // 套保商品id
	GOODSGROUPID   int32   `json:"goodsgroupid"  xorm:"'goodsgroupid'"`     // 商品组id
	CONVERTRATIO   float64 `json:"convertratio"  xorm:"'convertratio'"`     // 折算系数(品种系数)
	EXEXCHANGECODE string  `json:"exexchangecode"  xorm:"'exexchangecode'"` // 交易所代码
	GOODSGROUPNAME string  `json:"goodsgroupname"  xorm:"'goodsgroupname'"` // 商品组名称
	GOODSUNITID    int32   `json:"goodsunitid"  xorm:"'GOODUNITID'"`        // 单位id
	ENUMDICNAME    string  `json:"enumdicname"`                             // 单位名称
	AREAUSERID     int64   `json:"-"`                                       // 所属机构id
}

func (r *Ermcp3MiddleGoodsRelateGroup) calc() {
	r.ENUMDICNAME = mtpcache.GetEnumDicitemName(r.GOODSUNITID)
}

func (r *Ermcp3MiddleGoodsRelateGroup) buildSql() string {
	var sqlId utils.SQLVal = "select mg.areauserid," +
		"       mg.middlegoodsid," +
		"       gc.convertratio," +
		"       ex.exexchangecode," +
		"       gp.goodsgroupname," +
		"       gp.goodunitid," +
		"       gp.goodsgroupid" +
		"  from erms_middlegoods mg" +
		" inner join ERMCP_GGConvertConfig gc" +
		"    on mg.goodsgroupid = gc.destgoodsgroupid" +
		" inner join goodsgroup gp" +
		"    on gc.srcgoodsgroupid = gp.goodsgroupid" +
		"  left join externalexchange ex" +
		"    on gp.exexchangeid = ex.autoid" +
		" where mg.isvalid = 1" +
		"   and gp.goodsgroupstatus = 1"
	sqlId.AndEx("mg.AREAUSERID", r.AREAUSERID, r.AREAUSERID > 0)
	return sqlId.String()
}

// GetData 套保品关联的期货商品组信息
func (r *Ermcp3MiddleGoodsRelateGroup) GetData() ([]Ermcp3MiddleGoodsRelateGroup, error) {
	sData := make([]Ermcp3MiddleGoodsRelateGroup, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// GetDataEx 套保品关联的期货商品组信息
func (r *Ermcp3MiddleGoodsRelateGroup) GetDataEx() (interface{}, error) {
	return r.GetData()
}

// Ermcp3GoodsGroupEx 商品组(含商品列表)
type Ermcp3GoodsGroupEx struct {
	MIDDLEGOODSID  uint32        `json:"middlegoodsid"  xorm:"'middlegoodsid'"`   // 套保商品id
	GOODSGROUPID   int32         `json:"goodsgroupid"  xorm:"'goodsgroupid'"`     // 商品组id
	CONVERTRATIO   float64       `json:"convertratio"  xorm:"'convertratio'"`     // 折算系数(品种系数)
	EXEXCHANGECODE string        `json:"exexchangecode"  xorm:"'exexchangecode'"` // 交易所代码
	GOODSGROUPNAME string        `json:"goodsgroupname"  xorm:"'goodsgroupname'"` // 商品组名称
	GOODSUNITID    int32         `json:"goodsunitid"  xorm:"'GOODSUNITID'"`       // 单位id
	ENUMDICNAME    string        `json:"enumdicname"`                             // 单位名称
	GList          []Ermcp3Goods `json:"glist"`                                   // 合约列表
}

// Ermcp3Goods 商品信息
type Ermcp3Goods struct {
	GOODSID        int32   `json:"goodsid"  xorm:"'goodsid'"`               // 期货商品id
	GOODSCODE      string  `json:"goodscode"  xorm:"'goodscode'"`           // 期货商品代码
	GOODSNAME      string  `json:"goodsname"  xorm:"'goodsname'"`           // 期货商品名称
	AGREEUNIT      float32 `json:"agreeunit"  xorm:"'agreeunit'"`           // 合约单位(合约乘数)
	EXEXCHANGECODE string  `json:"exexchangecode"  xorm:"'exexchangecode'"` // 交易所代码
	ENUMDICNAME    string  `json:"enumdicname"`                             // 单位名称
}

// Ermcp3GoodsEx 套保品关联的期货商品(少量字段)
type Ermcp3GoodsEx struct {
	MIDDLEGOODSID  uint32  `json:"middlegoodsid"  xorm:"'middlegoodsid'"`   // 套保商品id
	GOODSID        int32   `json:"goodsid"  xorm:"'goodsid'"`               // 期货商品id
	GOODSCODE      string  `json:"goodscode"  xorm:"'goodscode'"`           // 期货商品代码
	GOODSNAME      string  `json:"goodsname"  xorm:"'goodsname'"`           // 期货商品名称
	GOODUNITID     int32   `json:"goodunitid"  xorm:"'goodunitid'"`         // 期货商品单位id
	CONVERTRATIO   float64 `json:"convertratio"  xorm:"'convertratio'"`     // 折算系数(品种系数)
	GOODSGROUPID   int32   `json:"goodsgroupid"  xorm:"'goodsgroupid'"`     // 商品组id
	EXEXCHANGECODE string  `json:"exexchangecode"  xorm:"'exexchangecode'"` // 交易所代码
	GOODSGROUPNAME string  `json:"goodsgroupname"  xorm:"'goodsgroupname'"` // 商品组名称
	GPUNITID       int32   `json:"gpunitid"  xorm:"'gpunitid'"`             // 商品组单位id
	AGREEUNIT      float32 `json:"agreeunit"  xorm:"'agreeunit'"`           // 合约单位(合约乘数)

	ENUMDICNAME   string `json:"enumdicname"` // 单位名称
	GPENUMDICNAME string `json:"enumdicname"` // 商品组单位名称
	AREAUSERID    int64  `json:"-"`           // 所属机构id
}

func (r *Ermcp3GoodsEx) calc() {
	r.ENUMDICNAME = mtpcache.GetEnumDicitemName(r.GOODUNITID)
	r.GPENUMDICNAME = mtpcache.GetEnumDicitemName(r.GPUNITID)
}

func (r *Ermcp3GoodsEx) buildSql() string {
	var sqlId utils.SQLVal = "select mg.areauserid," +
		"       mg.middlegoodsid," +
		"       g.goodsid," +
		"       g.goodscode," +
		"       g.goodsname," +
		"       g.goodunitid," +
		"       g.goodsgroupid," +
		"       g.agreeunit," +
		"       gc.convertratio," +
		"       ex.exexchangecode," +
		"       gp.goodsgroupname," +
		"       gp.goodunitid gpunitid" +
		"  from erms_middlegoods mg" +
		" inner join ERMCP_GGConvertConfig gc" +
		"    on mg.goodsgroupid = gc.destgoodsgroupid" +
		" inner join goodsgroup gp" +
		"    on gc.srcgoodsgroupid = gp.goodsgroupid" +
		" inner join goods g" +
		"    on gp.goodsgroupid = g.goodsgroupid" +
		"  left join externalexchange ex" +
		"    on gp.exexchangeid = ex.autoid" +
		" where g.goodsstatus not in(4,5,6) and mg.isvalid=1 and gp.goodsgroupstatus=1"
	sqlId.AndEx("mg.areauserid", r.AREAUSERID, r.AREAUSERID > 0)
	sqlId.Join(" order by mg.middlegoodsid")
	return sqlId.String()
}

// GetData
func (r *Ermcp3GoodsEx) GetData() ([]Ermcp3GoodsEx, error) {
	sData := make([]Ermcp3GoodsEx, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// GetDataEx
func (r *Ermcp3GoodsEx) GetDataEx() (interface{}, error) {
	return r.GetData()
}

// Ermcp3Contract 现货合同
type Ermcp3Contract struct {
	SPOTCONTRACTID    string  `json:"spotcontractid"  xorm:"'SPOTCONTRACTID'"`       // 现货合同ID(602+Unix秒时间戳(10位)+xxxxxx)
	CONTRACTNO        string  `json:"contractno"  xorm:"'CONTRACTNO'"`               // 现货合同编号
	CONTRACTTYPE      int32   `json:"contracttype"  xorm:"'CONTRACTTYPE'"`           // 现货合同类型 - 1:采购 -1:销售
	USERID            int64   `json:"userid"  xorm:"'USERID'"`                       // 所属机构ID
	BUYUSERID         int64   `json:"buyuserid"  xorm:"'BUYUSERID'"`                 // 采购方ID
	BUYUSERName       string  `json:"buyusername"  xorm:"'BUYUSERName'"`             // 采购方名称
	SELLUSERID        int64   `json:"selluserid"  xorm:"'SELLUSERID'"`               // 销售方ID
	SELLUSERNAME      string  `json:"sellusername"  xorm:"'SELLUSERNAME'"`           // 销售方名称
	DELIVERYGOODSID   int32   `json:"deliverygoodsid"  xorm:"'DELIVERYGOODSID'"`     // 现货品种ID
	WRSTANDARDID      int32   `json:"wrstandardid"  xorm:"'wrstandardid'"`           // 品类ID
	WRSTANDARDNAME    string  `json:"wrstandardname"  xorm:"'WRSTANDARDNAME'"`       // 品类名称
	WRSTANDARDCODE    string  `json:"wrstandardcode"  xorm:"'WRSTANDARDCODE'"`       // 品类代码
	DELIVERYGOODSCODE string  `json:"deliverygoodscode"  xorm:"'DELIVERYGOODSCODE'"` // 现货品种代码
	DELIVERYGOODSNAME string  `json:"deliverygoodsname"  xorm:"'DELIVERYGOODSNAME'"` // 现货品种名称
	PRODUCTTYPE       int32   `json:"producttype"  xorm:"'PRODUCTTYPE'"`             // 产品类型 - 1:标准仓单 2:等标 3:非标
	CONVERTFACTOR     float64 `json:"convertfactor"  xorm:"'CONVERTFACTOR'"`         // 标仓系数(品类)
	SPOTGOODSDESC     string  `json:"spotgoodsdesc"  xorm:"'SPOTGOODSDESC'"`         // 商品型号
	PRICETYPE         int32   `json:"pricetype"  xorm:"'PRICETYPE'"`                 // 定价类型 - 1:一口价 2:点价 3:暂定价
	QTY               float64 `json:"qty"  xorm:"'QTY'"`                             // 数量
	PRICE             float64 `json:"price"  xorm:"'PRICE'"`                         // 价格\暂定价 [1:一口价、3:暂定价]
	AMOUNT            float64 `json:"amount"  xorm:"'AMOUNT'"`                       // 金额 [1:一口价、3:暂定价]
	DELIVERYSTARTDATE string  `json:"deliverystartdate"  xorm:"'DELIVERYSTARTDATE'"` // 交收期(开始)
	DELIVERYENDDATE   string  `json:"deliveryenddate"  xorm:"'DELIVERYENDDATE'"`     // 交收期(结束)
	GOODSID           int32   `json:"goodsid"  xorm:"'GOODSID'"`                     // 点价合约ID - 0:为现货，其它为期货商品合约ID [2:点价 3:暂定价]
	GOODSCODE         string  `json:"goodscode"  xorm:"'GOODSCODE'"`                 // 点价合约代码
	GOODSNAME         string  `json:"goodsname"  xorm:"'GOODSNAME'"`                 // 点价商品名称
	PRICEMOVE         float64 `json:"pricemove"  xorm:"'PRICEMOVE'"`                 // 升贴水 [2:点价 3:暂定价]
	STARTDATE         string  `json:"startdate"  xorm:"'STARTDATE'"`                 // 点价开始日期 [2:点价 3:暂定价]
	ENDDATE           string  `json:"enddate"  xorm:"'ENDDATE'"`                     // 点价结束日期 [2:点价 3:暂定价]
	MARGIN            float64 `json:"margin"  xorm:"'MARGIN'"`                       // 当前保证金
	CONTRACTMARGIN    float64 `json:"contractmargin"  xorm:"'CONTRACTMARGIN'"`       // 合同保证金
	EnumdicName       string  `json:"enumdicname"  xorm:"'ENUMDICNAME'"`             // 单位名称
	CONTRACCTSTATUS   int32   `json:"contracctstatus"  xorm:"'CONTRACTSTATUS'"`      // 合同状态 - 0:未提交 1:待审核 2:执行中 3:正常完结 4:审核拒绝 5:异常完结 6:已撤回
	Remark            string  `json:"remark"  xorm:"'Remark'"`                       // 备注
	AUDITREMARK       string  `json:"auditremark"  xorm:"'AUDITREMARK'"`             // 审核意见
	AUDITTIME         string  `json:"audittime"  xorm:"'AUDITTIME'"`                 // 审核时间
	CREATETIME        string  `json:"createtime"  xorm:"'CREATETIME'"`               // 创建时间
	UPDATETIME        string  `json:"updatetime"  xorm:"'UPDATETIME'"`               // 更新时间
	SPOTGOODSBRANDID  int32   `json:"spotgoodsbrandid"  xorm:"'SPOTGOODSBRANDID'"`   // 现货品牌ID(DGFactoryItem表的ID)
	BRANDNAME         string  `json:"brandname"  xorm:"'brandname'"`                 // 品牌名称
	ATTACHMENT        string  `json:"attachment"  xorm:"'ATTACHMENT'"`               // 附件
	UNITID            int32   `json:"unitid"  xorm:"'UNITID'"`                       // 单位id(取品类上的单位id)
	TRADEUSERID       int64   `json:"tradeuserid"  xorm:"'TRADEUSERID'"`             // 交易员id
	SALEUSERID        int64   `json:"saleuserid"  xorm:"'SALEUSERID'"`               // 业务员id
	MERUSERID         int64   `json:"meruserid"  xorm:"'MERUSERID'"`                 // 跟单员id
	ACCOUNTID         string  `json:"accountid"  xorm:"'ACCOUNTID'"`                 // 期货账户id
	BIZTYPE           int32   `json:"biztype"  xorm:"'BIZTYPE'"`                     // 业务类型 1-套保 2-套利
	CURRENCYID        int32   `json:"currencyid"  xorm:"'CURRENCYID'"`               // 币种id
	SUBJECTID         string  `json:"subjectid"  xorm:"'SUBJECTID'"`                 // 交易主体ID
	SUBJECTNAME       string  `json:"subjectname"  xorm:"'SUBJECTNAME'"`             // 交易主体名称

	SELLNICKNAME       string `json:"sellnickname"`       // 采购方昵称
	BUYNICKNAME        string `json:"buynickname"`        // 销售方昵称
	TRADEUSERLOGINCODE string `json:"tradeuserlogincode"` // 交易员登录代码
	SALEUSERLOGINCODE  string `json:"saleuserlogincode"`  // 业务员登录代码
	MERUSERLOGINCODE   string `json:"meruserlogincode"`   // 跟单员登录代码
	CURRENCYNAME       string `json:"currencyname"`       // 币种名称
	TRADEUSERNAME      string `json:"tradeusername"`      // 交易员名称
	SALEUSERNAME       string `json:"saleusername"`       // 业务员名称
	MERUSERNAME        string `json:"merusername"`        // 跟单员名称

	// 筛选条件
	QryType   int32 `json:"-"` // 查询类型 1-未提交 2-待审核 3-履约中 4-已完成
	UserType  int32 `json:"-"` // 用户类型  2-管理员 7-企业成员
	OwnUserId int64 `json:"-"` // 登录用户id
}

func (r *Ermcp3Contract) getQryTypeStatus() string {
	var status string
	switch r.QryType {
	case 1: // 未提交
		status = "0,4,6"
	case 2: // 待审核
		status = "1"
	case 3: // 履约中
		status = "2"
	case 4: // 已完成
		status = "3,5"
	}
	return status
}

func (r *Ermcp3Contract) calc() {
	r.BUYUSERName, r.BUYNICKNAME = mtpcache.GetUserNameAndNickName(r.BUYUSERID)
	r.SELLUSERNAME, r.SELLNICKNAME = mtpcache.GetUserNameAndNickName(r.SELLUSERID)
	r.EnumdicName = mtpcache.GetEnumDicitemName(r.UNITID)
	r.TRADEUSERLOGINCODE = mtpcache.GetLoginCodeByUserId(r.TRADEUSERID)
	r.SALEUSERLOGINCODE = mtpcache.GetLoginCodeByUserId(r.SALEUSERID)
	r.MERUSERLOGINCODE = mtpcache.GetLoginCodeByUserId(r.MERUSERID)
	r.TRADEUSERNAME = mtpcache.GetUserNameByUserId(r.TRADEUSERID)
	r.CURRENCYNAME = mtpcache.GetCurrencyName(r.CURRENCYID)
	r.SALEUSERNAME = mtpcache.GetUserNameByUserId(r.SALEUSERID)
	r.MERUSERNAME = mtpcache.GetUserNameByUserId(r.MERUSERID)
}

func (r *Ermcp3Contract) buildSql() string {
	var sqlId utils.SQLVal = `
SELECT to_char(t.SPOTCONTRACTID) SPOTCONTRACTID,
       t.CONTRACTNO,
       t.CONTRACTTYPE,
       t.USERID,
       t.BUYUSERID,
       t.SELLUSERID,
       t.DELIVERYGOODSID,
       t.wrstandardid,
       t.PRODUCTTYPE,
       w.CONVERTFACTOR,
       t.SPOTGOODSDESC,
       t.PRICETYPE,
       t.QTY,
       t.PRICE,
       t.AMOUNT,
       to_char(t.DELIVERYSTARTDATE, 'yyyy-mm-dd hh24:mi:ss') DELIVERYSTARTDATE,
       to_char(t.DELIVERYENDDATE, 'yyyy-mm-dd hh24:mi:ss') DELIVERYENDDATE,
       t.GOODSID,
       t.PRICEMOVE,
       to_char(t.STARTDATE, 'yyyy-mm-dd hh24:mi:ss') STARTDATE,
       to_char(t.ENDDATE, 'yyyy-mm-dd hh24:mi:ss') ENDDATE,
       t.MARGIN,
       t.contractmargin,
       t.remark,
       t.auditremark,
       to_char(t.contractattachment) attachment,
       t.contractstatus,
       t.SPOTGOODSBRANDID,
       to_char(t.audittime, 'yyyy-mm-dd hh24:mi:ss') audittime,
       to_char(t.createtime, 'yyyy-mm-dd hh24:mi:ss') createtime,
       to_char(t.updatetime, 'yyyy-mm-dd hh24:mi:ss') updatetime,
       g.deliverygoodscode,
       g.deliverygoodsname,
       g2.goodscode,
       g2.goodsname,
       gb.dgfactoryitemvalue brandname,
       w.wrstandardname,
       w.wrstandardcode,
       w.unitid,
       t.tradeuserid,
       t.saleuserid,
       t.meruserid,
       t.currencyid,
       to_char(t.accountid) accountid,
       t.biztype,
       to_char(t.subjectid) subjectid,
       b.subjectname
  FROM ERMCP_SPOTCONTRACT t
  left join ermcp_pa_areasubject b on t.subjectid=b.subjectid
  left join deliverygoods g
    on t.deliverygoodsid = g.deliverygoodsid
  left join goods g2
    on t.goodsid = g2.goodsid
  left join DGFACTORYITEM gb
    on t.spotgoodsbrandid = gb.dgfactoryitemid
  left join wrstandard w
    on t.wrstandardid = w.wrstandardid
  left join loginaccount l
    on t.applyid = l.loginid
 where 1 = 1
`
	sqlId.AndEx("t.SPOTCONTRACTID", r.SPOTCONTRACTID, len(r.SPOTCONTRACTID) > 0)
	// 用户条件
	sqlId.Join(fmt.Sprintf(" and %v in(t.userid, t.saleuserid, t.tradeuserid, t.meruserid, l.userid)", r.OwnUserId))
	status := r.getQryTypeStatus()
	if len(status) > 0 {
		sqlId.Join(fmt.Sprintf(" and t.contractstatus in (%v)", status))
	}

	return sqlId.String()
}

// GetDataEx
func (r *Ermcp3Contract) GetDataEx() (interface{}, error) {
	sData := make([]Ermcp3Contract, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// Ermcp3SellBuyContract 采购/销售合同
type Ermcp3SellBuyContract struct {
	UserID             int64   `json:"userid"  xorm:"'UserID'"`                         // 机构ID
	SpotContractId     string  `json:"spotcontractid"  xorm:"'SPOTCONTRACTID'"`         // 合同ID
	AccountName        string  `json:"accountname"  xorm:"'ACCOUNTNAME'"`               // 账户名称
	DeliveryGoodsId    int     `json:"deliverygoodsid"  xorm:"'DELIVERYGOODSID'"`       // 现货商品ID
	DeliveryGoodsCode  string  `json:"deliverygoodscode"  xorm:"'DELIVERYGOODSCODE'"`   // 现货品种代码
	DeliveryGoodsName  string  `json:"deliverygoodsname"  xorm:"'DELIVERYGOODSNAME'"`   // 现货品种名称
	SpotGoodsdesc      string  `json:"spotgoodsdesc"  xorm:"'SPOTGOODSDESC'"`           // 商品型号(商品规格)
	GoodsId            int     `json:"goodsid"  xorm:"'GOODSID'"`                       // 点价商品ID
	GOODSNAME          string  `json:"goodsname"  xorm:"'GOODSNAME'"`                   // 点价商品名称
	Goodscode          string  `json:"goodscode"  xorm:"'GOODSCODE'"`                   // 点价商品代码
	Pricemove          float64 `json:"pricemove"  xorm:"'PRICEMOVE'"`                   // 升贴水
	Qty                float64 `json:"qty"  xorm:"'QTY'"`                               // 合同量
	UnpricedQty        float64 `json:"unpricedqty"  xorm:"'UNPRICEDQTY'"`               // 未定价量
	PricedQty          float64 `json:"pricedqty"  xorm:"'PRICEDQTY'"`                   // 已定价量
	UnsureQty          float64 `json:"unsureqty"  xorm:"'UNSUREQTY'"`                   // 未确定量
	PayAmount          float64 `json:"payamount"  xorm:"'PAYAMOUNT'"`                   // 已收付额(收款或付款)
	UnpayAmount        float64 `json:"unpayamount"`                                     // 应收付款额(应支付或应收款)
	PrePayAmount       float64 `json:"prepayamount"`                                    // 预收付额
	InvoiceAmount      float64 `json:"invoiceamount"  xorm:"'INVOICEAMOUNT'"`           // 已开票额
	DaikaiAmount       float64 `json:"daikaiamount"  xorm:"'DAIKAIAMOUNT'"`             // 应收(开)票额
	PreInvoiceAmount   float64 `json:"preinvoiceamount"`                                // 预收(开)票额
	StartDate          string  `json:"startdate"  xorm:"'STARTDATE'"`                   // 点价开始日
	EndDate            string  `json:"enddate"  xorm:"'ENDDATE'"`                       // 点价结束日
	DeliveryStartDate  string  `json:"deliverystartdate"  xorm:"'DELIVERYSTARTDATE'"`   // 交割开始日
	DeliveryendDate    string  `json:"deliveryenddate"  xorm:"'DELIVERYENDDATE'"`       // 交割结束日
	Convertfactor      float64 `json:"convertfactor"  xorm:"'CONVERTFACTOR'"`           // 标仓系数(品类)
	EnumdicName        string  `json:"enumdicname"  xorm:"'ENUMDICNAME'"`               // 单位名称
	Contracctstatus    uint    `json:"contracctstatus"  xorm:"'CONTRACTSTATUS'"`        // 合同状态- 0:未提交 1:待审核 2:执行中 3:正常完结 4:审核拒绝 5:异常完结 6:已撤回
	PriceType          int     `json:"pricetype"  xorm:"'PRICETYPE'"`                   // 定价类型 - 1:一口价 2:点价 3:暂定价
	ProductType        int     `json:"producttype"  xorm:"'PRODUCTTYPE'"`               // 产品类型 - 1:标准仓单 2:等标 3:非标
	Contracttype       int32   `json:"contracttype"  xorm:"'CONTRACTTYPE'"`             // 合同类型 1-采购, -1-销售
	Pricedamount       float64 `json:"pricedamount"  xorm:"'PRICEDAMOUNT'"`             // 已定价额
	PricedAvg          float64 `json:"pricedavg"  xorm:"'PRICEDAVG'"`                   // 已点均价
	Margin             float64 `json:"margin"  xorm:"'MARGIN'"`                         // 保证金
	CONTRACTMARGIN     float64 `json:"contractmargin"  xorm:"'CONTRACTMARGIN'"`         // 合同保证金
	Remark             string  `json:"remark"  xorm:"'Remark'"`                         // 备注
	ATTACHMENT         string  `json:"attachment"  xorm:"'ATTACHMENT'"`                 // 附件
	ReckonRealQty      float64 `json:"reckonrealqty"  xorm:"'ReckonRealQty'"`           // 已确定量
	ReckonOtherAmount  float64 `json:"reckonotheramount"  xorm:"'ReckonOtherAmount'"`   // 其它费用
	ReckonAdjustAmount float64 `json:"reckonadjustamount"  xorm:"'ReckonAdjustAmount'"` // 调整金额
	Price              float64 `json:"price"  xorm:"'Price'"`                           // 价格
	LoanAmount         float64 `json:"loanamount"  xorm:"'LoanAmount'"`                 // 贷款总额=已定价额+调整金额
	Contractno         string  `json:"contractno"  xorm:"'Contractno'"`                 // 合同编号
	TotalAmount        float64 `json:"totalamount"  xorm:"'-'"`                         // 合计总额
	ReckonedAmount     float64 `json:"reckonedamount"  xorm:"'ReckonedAmount'"`         // 实际已收付额(已确定额,已收付总额-已退款总额)
	BUYUSERID          int64   `json:"-"  xorm:"'BUYUSERID'"`                           // 采购方ID
	SELLUSERID         int64   `json:"-"  xorm:"'SELLUSERID'"`                          // 销售方ID
	AUDITTIME          string  `json:"audittime"  xorm:"'AUDITTIME'"`                   // 审核时间
	CREATETIME         string  `json:"createtime"  xorm:"'CREATETIME'"`                 // 创建时间
	SPOTGOODSBRANDID   int32   `json:"spotgoodsbrandid"  xorm:"'SPOTGOODSBRANDID'"`     // 现货品牌ID(DGFactoryItem表的ID)
	BRANDNAME          string  `json:"brandname"  xorm:"'brandname'"`                   // 品牌名称
	WRSTANDARDID       int64   `json:"wrstandardid"  xorm:"'WRSTANDARDID'"`             // 品类ID
	WRSTANDARDNAME     string  `json:"wrstandardname"  xorm:"'WRSTANDARDNAME'"`         // 品类名称
	WRSTANDARDCODE     string  `json:"wrstandardcode"  xorm:"'WRSTANDARDCODE'"`         // 品类代码
	TRADEUSERID        int64   `json:"tradeuserid"  xorm:"'TRADEUSERID'"`               // 交易员id
	SALEUSERID         int64   `json:"saleuserid"  xorm:"'SALEUSERID'"`                 // 业务员id
	MERUSERID          int64   `json:"meruserid"  xorm:"'MERUSERID'"`                   // 跟单员id
	ACCOUNTID          string  `json:"accountid"  xorm:"'ACCOUNTID'"`                   // 期货账户id
	BIZTYPE            int32   `json:"biztype"  xorm:"'BIZTYPE'"`                       // 业务类型 1-套保 2-套利
	CURRENCYID         int32   `json:"currencyid"  xorm:"'CURRENCYID'"`                 // 币种id
	SUBJECTID          string  `json:"subjectid"  xorm:"'SUBJECTID'"`                   // 交易主体ID
	SUBJECTNAME        string  `json:"subjectname"  xorm:"'SUBJECTNAME'"`               // 交易主体名称

	NICKNAME           string `json:"nickname"`           // 账户昵称
	TRADEUSERLOGINCODE string `json:"tradeuserlogincode"` // 交易员登录代码
	SALEUSERLOGINCODE  string `json:"saleuserlogincode"`  // 业务员登录代码
	MERUSERLOGINCODE   string `json:"meruserlogincode"`   // 跟单员登录代码
	CURRENCYNAME       string `json:"currencyname"`       // 币种名称
	TRADEUSERNAME      string `json:"tradeusername"`      // 交易员名称
	SALEUSERNAME       string `json:"saleusername"`       // 业务员名称
	MERUSERNAME        string `json:"merusername"`        // 跟单员名称

	// 筛选条件
	QryType   int32 `json:"-"` // 查询类型 1-未提交 2-待审核 3-履约中 4-已完成
	UserType  int32 `json:"-"` // 用户类型  2-管理员 7-企业成员
	OwnUserId int64 `json:"-"` // 登录用户id
}

func (r *Ermcp3SellBuyContract) calc() {
	r.TotalAmount = r.LoanAmount + r.ReckonOtherAmount
	// #95629 公式变更 modify:2021-06-16 09:54:08
	// 应付款额=货款总额-已付款额+已退款额
	// 应收款额=货款总额-已收款额+已退款额
	r.UnpayAmount = r.LoanAmount - r.ReckonedAmount
	// 预付款额=已付款额-已退款额-货款总额
	// 预收款额=已收款额-已退款额-货款总额
	r.PrePayAmount = r.ReckonedAmount - r.LoanAmount
	// 预收票额=已收票额-货款总额
	// 预开票额=已开票额-货款总额
	r.PreInvoiceAmount = r.InvoiceAmount - r.LoanAmount

	// 应收票额=货款总额-已收票额
	// 应开票额=货款总额-已开票额
	r.DaikaiAmount = r.LoanAmount - r.InvoiceAmount

	if r.Contracttype == 1 {
		//采购合同, 取销售方名称
		r.AccountName, r.NICKNAME = mtpcache.GetUserNameAndNickName(r.SELLUSERID)
	} else {
		//销售合同, 取采购方名称
		r.AccountName, r.NICKNAME = mtpcache.GetUserNameAndNickName(r.BUYUSERID)
	}

	r.TRADEUSERLOGINCODE = mtpcache.GetLoginCodeByUserId(r.TRADEUSERID)
	r.SALEUSERLOGINCODE = mtpcache.GetLoginCodeByUserId(r.SALEUSERID)
	r.MERUSERLOGINCODE = mtpcache.GetLoginCodeByUserId(r.MERUSERID)
	r.TRADEUSERNAME = mtpcache.GetUserNameByUserId(r.TRADEUSERID)
	r.CURRENCYNAME = mtpcache.GetCurrencyName(r.CURRENCYID)
	r.SALEUSERNAME = mtpcache.GetUserNameByUserId(r.SALEUSERID)
	r.MERUSERNAME = mtpcache.GetUserNameByUserId(r.MERUSERID)
}

func (r *Ermcp3SellBuyContract) buildSql() string {
	var sqlId utils.SQLVal = `

select t.contractno,
       to_char(t.SpotContractId) SpotContractId,
       t.deliverygoodsid,
       t.spotgoodsdesc,
       t.goodsid,
       t.pricemove,
       t.userid,
       t.BUYUSERID,
       t.SELLUSERID,
       t.qty,
       t.qty - t.pricedqty unpricedqty,
       t.pricedqty,
       (case
         when t.pricetype = 3 then
          t.qty - t.RECKONREALQTY
         else
          t.pricedqty - nvl(t.ReckonRealQty, 0)
       end) unsureqty,
       t.reckonedamount PayAmount,
       t.invoiceamount,
       (t.pricedamount + t.RECKONADJUSTAMOUNT - t.invoiceamount) as daikaiAmount,
       to_char(t.startdate, 'yyyy-mm-dd hh24:mi:ss') startdate,
       to_char(t.enddate, 'yyyy-mm-dd hh24:mi:ss') enddate,
       to_char(t.deliverystartdate, 'yyyy-mm-dd hh24:mi:ss') deliverystartdate,
       to_char(t.deliveryenddate, 'yyyy-mm-dd hh24:mi:ss') deliveryenddate,
       wr.convertfactor,
       t.contractstatus,
       t.pricetype,
       t.producttype,
       t.contracttype,
       t.remark,
       to_char(t.contractattachment) attachment,
       t.margin,
       t.contractmargin,
       t.SPOTGOODSBRANDID,
       t.tradeuserid,
       t.saleuserid,
       t.meruserid,
       t.currencyid,
       t.biztype,
       g.deliverygoodscode,
       g.deliverygoodsname,
       wr.wrstandardid,
       wr.wrstandardname,
       wr.wrstandardcode,
       g2.goodscode,
       g2.goodsname,
       e.enumdicname,
       t.contracttype,
       t.pricedamount,
       case
         when t.pricedqty > 0 then
          (t.pricedamount) / t.pricedqty
         else
          0
       end pricedAvg,
       t.ReckonRealQty,
       t.ReckonOtherAmount,
       t.ReckonAdjustAmount,
       t.Price,
       t.ReckonedAmount,
       to_char(t.audittime, 'yyyy-mm-dd hh24:mi:ss') audittime,
       to_char(t.createtime, 'yyyy-mm-dd hh24:mi:ss') createtime,
       t.pricedamount + t.ReckonAdjustAmount as LoanAmount,
       gb.dgfactoryitemvalue BRANDNAME,
       to_char(t.subjectid) subjectid,
       b.subjectname
  from ermcp_spotcontract t
  left join ermcp_pa_areasubject b on t.subjectid=b.subjectid
  left join deliverygoods g
    on t.deliverygoodsid = g.deliverygoodsid
  left join goods g2
    on t.goodsid = g2.goodsid
  left join wrstandard wr
    on t.wrstandardid = wr.wrstandardid
  left join DGFactoryItem gb
    on t.spotgoodsbrandid = gb.dgfactoryitemid
  left join enumdicitem e
    on wr.unitid = e.enumitemname
   and e.enumdiccode = 'goodsunit'
 where 1 = 1
`
	sqlId.AndEx("t.userid", r.UserID, r.UserID > 0)
	sqlId.AndEx("t.contracttype", r.Contracttype, r.Contracttype != 0)
	sqlId.AndEx("t.SpotContractId", r.SpotContractId, len(r.SpotContractId) > 0)
	if r.UserType == 7 {
		// 企业成员
		sqlId.Join(fmt.Sprintf(" and %v in(t.saleuserid, t.tradeuserid, t.meruserid)", r.OwnUserId))
	}

	var status string
	nQueryType := r.QryType
	if 1 == nQueryType {
		// 全部
		status = "2,3"
	} else if 2 == nQueryType {
		// 待点价
		status = "2"
	} else {
		// 履约
		status = "2"
	}

	if len(status) > 0 {
		sqlId.Join(fmt.Sprintf(" and t.contractstatus in (%v)", status))
	}
	sqlId.JoinEx(r.QryType == 2, " and t.qty - t.pricedqty > 0 and t.pricetype !=1")
	return sqlId.String()
}

// GetDataEx
func (r *Ermcp3SellBuyContract) GetDataEx() (interface{}, error) {
	sData := make([]Ermcp3SellBuyContract, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// Ermcp3ExposureDetail 敞口现货明细
type Ermcp3ExposureDetail struct {
	Createtime        string  `json:"createtime"  xorm:"'createtime'"`               // 时间
	Areauserid        int64   `json:"areauserid"  xorm:"'areauserid'"`               // 机构ID
	Logtype           int32   `json:"logtype"  xorm:"'logtype'"`                     // 类型 - 1:套保计划 2:现货合同
	Contracttype      int32   `json:"contracttype"  xorm:"'contracttype'"`           // 现货合同类型 - 1:采购 -1:销售
	Qty               float64 `json:"qty"  xorm:"'qty'"`                             // 数量
	RelateNo          string  `json:"relateNo"  xorm:"'relateNo'"`                   // 现货合同/套保计划编号
	Middlegoodsname   string  `json:"middlegoodsname"  xorm:"'middlegoodsname'"`     // 套保商品名称
	Middlegoodscode   string  `json:"middlegoodscode"  xorm:"'middlegoodscode'"`     // 套保商品代码
	MiddlegoodsId     int32   `json:"middlegoodsId"  xorm:"'middlegoodsId'"`         // 套保商品id
	Unitid            int32   `json:"-"  xorm:"'unitid'"`                            // 现货商品单位ID
	Enumdicname       string  `json:"enumdicname"  xorm:"'enumdicname'"`             // 现货商品单位名称
	ChangeQty         float64 `json:"changeQty"  xorm:"'changeQty'"`                 // 套保变动量
	Convertfactor     float64 `json:"convertfactor"  xorm:"'convertfactor'"`         // 标仓系数
	Convertratio      float64 `json:"convertratio"  xorm:"'convertratio'"`           // 套保系数
	DELIVERYGOODSID   int32   `json:"deliverygoodsid"  xorm:"'DELIVERYGOODSID'"`     // 现货品种id
	DELIVERYGOODSCODE string  `json:"deliverygoodscode"  xorm:"'DELIVERYGOODSCODE'"` // 现货品种代码
	DELIVERYGOODSNAME string  `json:"deliverygoodsname"  xorm:"'DELIVERYGOODSNAME'"` // 现货品种名称
	MGUNITID          int32   `json:"mgunitid"  xorm:"'MGUNITID'"`                   // 套保品种单位id
	MGUNITIDNAME      string  `json:"mgunitidname"`                                  // 套保品种单位名称
}

func (r *Ermcp3ExposureDetail) calc() {
	// 销售合同转换为负数
	if r.Logtype == 2 && r.Contracttype == -1 {
		r.ChangeQty *= -1
		r.Qty *= -1
	}

	// 采购计划 转换为负数
	if r.Logtype == 1 && r.Contracttype == 1 {
		r.ChangeQty *= -1
		r.Qty *= -1
	}

	if r.Convertratio > 0 && r.Convertfactor > 0 {
		r.Qty = r.Qty / r.Convertfactor / r.Convertratio
	}
	r.MGUNITIDNAME = mtpcache.GetEnumDicitemName(r.MGUNITID)
}

func (r *Ermcp3ExposureDetail) buildSql() string {
	var sqlId utils.SQLVal = "with tmp as" +
		" (select 2                as LogType," +
		"         s.spotcontractid as relatedid," +
		"         s.contractno     as relateNo," +
		"         s.qty" +
		"    from ermcp_spotcontract s" +
		"  union all" +
		"  select 1," +
		"         t.hedgeplanid as relateid," +
		"         t.hedgeplanno as relateNo," +
		"         t.planqty     as qty" +
		"    from ermcp_hedgeplan t)" +
		"select to_char(t.createtime, 'yyyy-mm-dd hh24:mi:ss') createtime," +
		"       t.middlegoodsid," +
		"       t.areauserid," +
		"       t.logtype," +
		"       t.contracttype," +
		"       t.qty," +
		"       t.convertfactor," +
		"       t.convertratio," +
		"       t.qty changeQty," +
		"       tmp.relateNo," +
		"       m.middlegoodsname," +
		"       m.middlegoodscode," +
		"       m.goodsunitid mgunitid," +
		"       g.deliverygoodsid," +
		"       g.deliverygoodscode," +
		"       g.deliverygoodsname," +
		"       g.goodsunitid unitid," +
		"       e.enumdicname" +
		"  from ermcp_spotexposurelog t" +
		"  left join erms_middlegoods m" +
		"    on t.middlegoodsid = m.middlegoodsid" +
		"  left join deliverygoods g" +
		"    on t.deliverygoodsid = g.deliverygoodsid" +
		"  left join enumdicitem e" +
		"    on g.goodsunitid = e.enumitemname" +
		"   and e.enumdiccode = 'goodsunit'" +
		"  left join tmp" +
		"    on t.logtype = tmp.LogType" +
		"   and t.relatedid = tmp.relatedid" +
		" where 1=1 and t.tradedate=to_char(sysdate, 'yyyymmdd')"
	sqlId.And("t.areauserid", r.Areauserid)
	sqlId.And("t.middlegoodsid", r.MiddlegoodsId)
	return sqlId.String()
}

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

// Ermcp3AreaSpot 敞口现货头寸
type Ermcp3AreaSpot struct {
	AREAUSERID        int64   `json:"areauserid"  xorm:"'AREAUSERID'"`               // 所属机构
	ORIBUYPLANQTY     float64 `json:"-"  xorm:"'ORIBUYPLANQTY'"`                     // 期初采购计划数量
	ORIBUYPRICEDQTY   float64 `json:"-"  xorm:"'ORIBUYPRICEDQTY'"`                   // 期初采购合同已定价数量
	ORISELLPLANQTY    float64 `json:"-"  xorm:"'ORISELLPLANQTY'"`                    // 期初销售计划数量
	ORISELLPRICEDQTY  float64 `json:"-"  xorm:"'ORISELLPRICEDQTY'"`                  // 期初销售合同已定价数量
	BUYPLANQTY        float64 `json:"-"  xorm:"'BUYPLANQTY'"`                        // 采购计划数量
	BUYPRICEDQTY      float64 `json:"-"  xorm:"'BUYPRICEDQTY'"`                      // 采购合同已定价数量
	SELLPLANQTY       float64 `json:"-"  xorm:"'SELLPLANQTY'"`                       // 销售计划数量
	SELLPRICEDQTY     float64 `json:"-"  xorm:"'SELLPRICEDQTY'"`                     // 销售合同已定价数量
	TOTALSPOTQTY      float64 `json:"totalspotqty"  xorm:"'TOTALSPOTQTY'"`           // 当前数量(现货头寸总量) =  (销售计划数量 - 销售已定价数量)  - (采购计划数量 - 采购已定价数量)
	OriToalSpotQty    float64 `json:"oritoalspotqty"  xorm:"'OriToalSpotQty'"`       // 昨日数量
	IncreaseQty       float64 `json:"increaseqty"  xorm:"'IncreaseQty'"`             // 增加数量=销售计划数量+采购已定价数量
	DecreaseQty       float64 `json:"decreaseqty"  xorm:"'DecreaseQty'"`             // 减少数量=-(销售已定价数量+采购计划数量)
	UPDATETIME        string  `json:"updatetime"  xorm:"'UPDATETIME'"`               // 更新时间
	DELIVERYGOODSID   int32   `json:"deliverygoodsid"  xorm:"'DELIVERYGOODSID'"`     // 现货品种id
	DELIVERYGOODSCODE string  `json:"deliverygoodscode"  xorm:"'DELIVERYGOODSCODE'"` // 现货品种代码
	DELIVERYGOODSNAME string  `json:"deliverygoodsname"  xorm:"'DELIVERYGOODSNAME'"` // 现货品种名称
	GOODSUNITID       int32   `json:"goodsunitid"  xorm:"'GOODSUNITID'"`             // 现货品种单位id

	ENUMDICNAME string `json:"enumdicname"` // 单位名称
}

func (r *Ermcp3AreaSpot) calc() {
	/*
		增加数量=今日销售计划数量+今日采购已定价数量
		减少数量=-(今日销售已定价数量+今日采购计划数量)

		其中，
		今日销售计划数量=期末销售计划数量-期初销售计划数量
		今日采购已定价数量=期末采购已定价数量-期初采购已定价数量
		今日销售已定价数量=期末销售已定价数量-期初销售已定价数量
		今日采购计划数量=期末采购计划数量-期初采购计划数量
	*/
	r.IncreaseQty = r.SELLPLANQTY - r.ORISELLPLANQTY + r.BUYPRICEDQTY - r.ORIBUYPRICEDQTY
	r.DecreaseQty = (r.SELLPRICEDQTY - r.ORISELLPRICEDQTY + r.BUYPLANQTY - r.ORIBUYPLANQTY) * -1
	r.OriToalSpotQty = (r.ORISELLPLANQTY - r.ORISELLPRICEDQTY) - (r.ORIBUYPLANQTY - r.ORIBUYPRICEDQTY)
	r.ENUMDICNAME = mtpcache.GetEnumDicitemName(r.GOODSUNITID)
}

func (r *Ermcp3AreaSpot) buildSql() string {
	var sqlId utils.SQLVal = "select t.AREAUSERID," +
		"       t.ORIBUYPLANQTY," +
		"       t.ORIBUYPRICEDQTY," +
		"       t.ORISELLPLANQTY," +
		"       t.ORISELLPRICEDQTY," +
		"       t.BUYPLANQTY," +
		"       t.BUYPRICEDQTY," +
		"       t.SELLPLANQTY," +
		"       t.SELLPRICEDQTY," +
		"       t.TOTALSPOTQTY," +
		"       g.deliverygoodsid," +
		"       g.deliverygoodscode," +
		"       g.deliverygoodsname," +
		"       g.goodsunitid," +
		"       to_char(t.UPDATETIME, 'yyyy-mm-dd hh24:mi:ss') UPDATETIME" +
		"  from ermcp_areaspot t" +
		"  left join deliverygoods g" +
		"    on t.deliverygoodsid = g.deliverygoodsid" +
		" where 1 = 1"
	sqlId.And("t.areauserid", r.AREAUSERID)
	return sqlId.String()
}

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

// Ermcp3AreaSpotDetail 敞口现货头寸明细
type Ermcp3AreaSpotDetail struct {
	Relatedid         string  `json:"relatedid"  xorm:"'relatedid'"`                 // 套保计划ID/现货合同ID
	Relatedno         string  `json:"relatedno"  xorm:"'relatedno'"`                 // 编号
	LogType           int32   `json:"logtype"  xorm:"'logType'"`                     // 记录类型 1-套保 2-现货合同
	Contracttype      int32   `json:"contracttype"  xorm:"'contracttype'"`           // 合同类型 1-采购 -1-销售
	Qty               float64 `json:"qty"  xorm:"'qty'"`                             // 数量
	Strtime           string  `json:"strtime"  xorm:"'strtime'"`                     // 时间
	Enumdicname       string  `json:"enumdicname"`                                   // 现货商品单位名称
	Recordname        string  `json:"recordname"`                                    // 类型名称
	CREATETIME        string  `json:"createtime"  xorm:"'CREATETIME'"`               // 创建时间
	Unitid            int32   `json:"-"  xorm:"'UNITID'"`                            // 单位ID
	UserId            int64   `json:"-"`                                             // 所属用户ID
	DELIVERYGOODSID   int32   `json:"deliverygoodsid"  xorm:"'DELIVERYGOODSID'"`     // 现货品种id
	DELIVERYGOODSCODE string  `json:"deliverygoodscode"  xorm:"'DELIVERYGOODSCODE'"` // 现货品种代码
	DELIVERYGOODSNAME string  `json:"deliverygoodsname"  xorm:"'DELIVERYGOODSNAME'"` // 现货品种名称
}

func (r *Ermcp3AreaSpotDetail) calc() {
	var logTypeName, contractTypeName string
	if r.LogType == 1 {
		logTypeName = "计划"
	} else {
		logTypeName = "合同"
	}

	if r.Contracttype == 1 {
		contractTypeName = "采购"
	} else {
		contractTypeName = "销售"
	}

	// 销售合同 数量转为负数
	if r.LogType == 2 && r.Contracttype == -1 {
		if r.Qty > 0 {
			r.Qty = r.Qty * -1
		}
	}

	// 采购计划 数量转为负数
	if r.LogType == 1 && r.Contracttype == 1 {
		if r.Qty > 0 {
			r.Qty = r.Qty * -1
		}
	}

	r.Recordname = contractTypeName + logTypeName
	r.Enumdicname = mtpcache.GetEnumDicitemName(r.Unitid)
}

func (r *Ermcp3AreaSpotDetail) buildSql() string {
	var sqlId utils.SQLVal = "with tmp as" +
		" (select to_char(t.hedgeplanid) relatedid," +
		"         t.hedgeplanno relatedno," +
		"         1 as logType," +
		"         t.contracttype" +
		"    from ermcp_hedgeplan t" +
		"   where  %v in(t.areauserid, t.tradeuserid)" +
		"     and t.deliverygoodsid = %v" +
		"  union all" +
		"  select to_char(t.spotcontractid)," +
		"         t.contractno," +
		"         2 as logType," +
		"         t.contracttype" +
		"    from ermcp_spotcontract t" +
		"   where %v in(t.userid, t.tradeuserid)" +
		"     and t.deliverygoodsid = %v)" +
		"select t.relatedid," +
		"       tmp.relatedno," +
		"       t.LogType," +
		"       tmp.contracttype," +
		"       t.RealQty qty," +
		"       to_char(t.createtime, 'yyyy-mm-dd hh24:mi:ss') createtime," +
		"       g.deliverygoodsid," +
		"       g.deliverygoodsname," +
		"       g.deliverygoodscode," +
		"       g.goodsunitid unitid" +
		"  from ermcp_spotlog t" +
		" inner join tmp" +
		"    on t.LogType = tmp.logType" +
		"   and t.relatedid = tmp.relatedid" +
		"   and t.areauserid = %v" +
		"   and t.deliverygoodsid = %v" +
		"  left join deliverygoods g" +
		"    on t.deliverygoodsid = g.deliverygoodsid" +
		" where t.tradedate = to_char(sysdate, 'yyyymmdd')"
	sqlId.FormatParam(r.UserId, r.DELIVERYGOODSID, r.UserId, r.DELIVERYGOODSID, r.UserId, r.DELIVERYGOODSID)
	return sqlId.String()
}

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

// Ermcp3Wrstandard 现货品类
type Ermcp3Wrstandard struct {
	WRSTANDARDID    int64   `json:"wrstandardid"  xorm:"'WRSTANDARDID'"`       // 品类ID(SEQ_WRSTANDARD)
	WRSTANDARDCODE  string  `json:"wrstandardcode"  xorm:"'WRSTANDARDCODE'"`   // 品类代码
	DELIVERYGOODSID int32   `json:"deliverygoodsid"  xorm:"'DELIVERYGOODSID'"` // 现货品种ID
	UNITID          int32   `json:"unitid"  xorm:"'UNITID'"`                   // 品类单位ID
	MINIVALUE       int32   `json:"minivalue"  xorm:"'MINIVALUE'"`             // 最小变动值
	MINIVALUEDP     int32   `json:"minivaluedp"  xorm:"'MINIVALUEDP'"`         // 最小变动值小数位
	REALMINIVALUE   int32   `json:"realminivalue"  xorm:"'REALMINIVALUE'"`     // 实际最小变动值
	REALMINIVALUEDP int32   `json:"realminivaluedp"  xorm:"'REALMINIVALUEDP'"` // 实际最小变动值小数位
	CREATORID       int64   `json:"creatorid"  xorm:"'CREATORID'"`             // 创建人
	CREATETIME      string  `json:"createtime"  xorm:"'CREATETIME'"`           // 创建时间
	WRSTANDARDNAME  string  `json:"wrstandardname"  xorm:"'WRSTANDARDNAME'"`   // 品类名称
	AREAUSERID      int64   `json:"areauserid"  xorm:"'AREAUSERID'"`           // 所属机构
	EnumdicName     string  `json:"enumdicname"`                               // 品类单位名称
	ISVALID         int32   `json:"isvalid"  xorm:"'ISVALID'"`                 // 是否有效 0-无效(停用) 1-有效(正常)
	UPDATETIME      string  `json:"updatetime"  xorm:"'UPDATETIME'"`           // 更新时间
	REMARK          string  `json:"remark"  xorm:"'REMARK'"`                   // 备注
	CONVERTFACTOR   float64 `json:"convertfactor"  xorm:"'CONVERTFACTOR'"`     // 标仓系数
	CANTRADE        int32   `json:"cantrade"  xorm:"'CANTRADE'"`               // 是否允许交易 - 0:不允许 1:允许 -1:未配置(数据库里没有记录)
}

func (r *Ermcp3Wrstandard) calc() {
	r.EnumdicName = mtpcache.GetEnumDicitemName(r.UNITID)
}

func (r *Ermcp3Wrstandard) buildSql() string {
	sqlId := "select t.WRSTANDARDID," +
		"       t.WRSTANDARDCODE," +
		"       t.DELIVERYGOODSID," +
		"       t.UNITID," +
		"       t.MINIVALUE," +
		"       t.MINIVALUEDP," +
		"       t.REALMINIVALUE," +
		"       t.REALMINIVALUEDP," +
		"       t.CREATORID," +
		"       to_char(t.CREATETIME, 'yyyy-mm-dd hh24:mi:ss') CREATETIME," +
		"       t.WRSTANDARDNAME," +
		"       t.ISVALID," +
		"       to_char(t.UPDATETIME, 'yyyy-mm-dd hh24:mi:ss') UPDATETIME," +
		"       t.REMARK," +
		"       t.CONVERTFACTOR," +
		"       t.AREAUSERID," +
		"       nvl(m.cantrade,-1) cantrade" +
		"  from wrstandard t" +
		"  left join marketspotgoodsconfig m on t.wrstandardid = m.wrstandardid" +
		" where 1 = 1"
	if r.AREAUSERID > 0 {
		sqlId += fmt.Sprintf(" and t.AREAUSERID=%v", r.AREAUSERID)
	}
	if r.DELIVERYGOODSID > 0 {
		sqlId = sqlId + fmt.Sprintf(" and t.DELIVERYGOODSID=%v", r.DELIVERYGOODSID)
	}
	sqlId += " order by createtime desc"
	return sqlId
}

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

// Ermcp3AreaStockApply 出入库申请
type Ermcp3AreaStockApply struct {
	INOUTAPPLYID      string  `json:"inoutapplyid"  xorm:"'INOUTAPPLYID'"`           // 申请ID(607+Unix秒时间戳(10位)+xxxxxx)
	USERID            int64   `json:"userid"  xorm:"'USERID'"`                       // 机构ID
	INOUTTYPE         int32   `json:"inouttype"  xorm:"'INOUTTYPE'"`                 // 出入库类型 - 5:采购入库 6:销售出库 7:生产入库 8:生产出库
	WRSTANDARDID      int32   `json:"wrstandardid"  xorm:"'WRSTANDARDID'"`           // 品类ID
	SPOTGOODSBRANDID  int32   `json:"spotgoodsbrandid"  xorm:"'SPOTGOODSBRANDID'"`   // 现货品牌ID
	SPOTCONTRACTID    string  `json:"spotcontractid"  xorm:"'SPOTCONTRACTID'"`       // 关联现货合同ID
	WAREHOUSEINFOID   string  `json:"warehouseinfoid"  xorm:"'WAREHOUSEINFOID'"`     // 现货仓库ID
	APPLYSTATUS       int32   `json:"applystatus"  xorm:"'APPLYSTATUS'"`             // 申请状态 - 1:待审核 2:审核通过 3:审核拒绝 4:处理失败 5:已撤回
	APPLYSRC          int32   `json:"applysrc"  xorm:"'APPLYSRC'"`                   // 申请来源 - 1:管理端 2:终端
	APPLYID           int64   `json:"applyid"  xorm:"'APPLYID'"`                     // 申请人
	APPLYREMARK       string  `json:"applyremark"  xorm:"'APPLYREMARK'"`             // 申请备注
	APPLYTIME         string  `json:"applytime"  xorm:"'APPLYTIME'"`                 // 申请时间
	AUDITSRC          int32   `json:"auditsrc"  xorm:"'AUDITSRC'"`                   // 审核来源 - 1:管理端 2:终端
	AUDITID           int64   `json:"auditid"  xorm:"'AUDITID'"`                     // 审核人
	AUDITTIME         string  `json:"audittime"  xorm:"'AUDITTIME'"`                 // 审核时间
	AUDITREMARK       string  `json:"auditremark"  xorm:"'AUDITREMARK'"`             // 审核备注
	AUDITTRADEDATE    string  `json:"audittradedate"  xorm:"'AUDITTRADEDATE'"`       // 审核交易日(yyyyMMdd)
	WRSTANDARDNAME    string  `json:"wrstandardname"  xorm:"'WRSTANDARDNAME'"`       // 品类名称
	WRSTANDARDCODE    string  `json:"wrstandardcode"  xorm:"'WRSTANDARDCODE'"`       // 品类代码
	UNITID            int32   `json:"unitid"  xorm:"'UNITID'"`                       // 单位id
	BRANDNAME         string  `json:"brandname"  xorm:"'BRANDNAME'"`                 // 品牌名称
	WAREHOUSENAME     string  `json:"warehousename"  xorm:"'WAREHOUSENAME'"`         // 仓库名称
	WAREHOUSECODE     string  `json:"warehousecode"  xorm:"'WAREHOUSECODE'"`         // 仓库代码
	WAREHOUSETYPE     int32   `json:"warehousetype"  xorm:"'WAREHOUSETYPE'"`         // 仓库类型 - 1 厂库  2 自有库  3 合作库
	CONTRACTNO        string  `json:"contractno"  xorm:"'CONTRACTNO'"`               // 合同编号
	CONTRACTTYPE      int32   `json:"contracttype"  xorm:"'CONTRACTTYPE'"`           // 现货合同类型 - 1:采购 -1:销售
	BUYUSERID         int64   `json:"buyuserid"  xorm:"'BUYUSERID'"`                 // 采购方userid
	SELLUSERID        int64   `json:"selluserid"  xorm:"'SELLUSERID'"`               // 销售方userid
	PRICETYPE         int32   `json:"pricetype"  xorm:"'PRICETYPE'"`                 // 定价类型 - 1:一口价 2:点价 3:暂定价
	CONTRACTQTY       float64 `json:"contractqty"  xorm:"'CONTRACTQTY'"`             // 合同量
	DETAILJSON        string  `json:"detailjson"  xorm:"'DETAILJSON'"`               // 明细数据
	BUYUSERNAME       string  `json:"buyusername"`                                   // 采购方名称
	SELLUSERNAME      string  `json:"sellusername"`                                  // 销售方名称
	APPLYNAME         string  `json:"applyname"`                                     // 申请人名称
	AUDITNAME         string  `json:"auditname"`                                     // 审核人名称
	ENUMDICNAME       string  `json:"enumdicname"`                                   // 现货商品单位名称
	DELIVERYGOODSID   int32   `json:"deliverygoodsid"  xorm:"'DELIVERYGOODSID'"`     // 现货品种id
	DELIVERYGOODSCODE string  `json:"deliverygoodscode"  xorm:"'DELIVERYGOODSCODE'"` // 现货品种代码
	DELIVERYGOODSNAME string  `json:"deliverygoodsname"  xorm:"'DELIVERYGOODSNAME'"` // 现货品种名称
	BUYNICKNAME       string  `json:"buynickname"`                                   // 采购方昵称
	SELLNICKNAME      string  `json:"sellnickname"`                                  // 销售方昵称
	QTY               float64 `json:"qty"`                                           // 数量

	FilterStatus string `json:"-"` // 查询条件, 申请状态, 逗号隔开
	FilterType   string `json:"-"` // 查询条件, 出入库类型, 逗号隔开
	BeginDate    string `json:"-"` // 开始日期
	EndDate      string `json:"-"` // 结束日期
	UserType     int32  `json:"-"` // 用户类型
}

func (r *Ermcp3AreaStockApply) calc() {
	// 采购方名称
	r.BUYUSERNAME, r.BUYNICKNAME = mtpcache.GetUserNameAndNickName(r.BUYUSERID)
	// 销售方名称
	r.SELLUSERNAME, r.SELLNICKNAME = mtpcache.GetUserNameAndNickName(r.SELLUSERID)
	// 申请人名称
	if r.APPLYSRC == 1 {
		r.APPLYNAME = mtpcache.GetSystemmangerLoginCode(r.APPLYID)
	} else {
		r.APPLYNAME = mtpcache.GetLoginCodeByLoginId(r.APPLYID)
	}
	// 审核人名称
	if r.AUDITSRC == 1 {
		r.AUDITNAME = mtpcache.GetSystemmangerLoginCode(r.AUDITID)
	} else {
		r.AUDITNAME = mtpcache.GetLoginCodeByLoginId(r.AUDITID)
	}
	// 单位名称
	r.ENUMDICNAME = mtpcache.GetEnumDicitemName(r.UNITID)

	if len(r.DETAILJSON) > 0 {
		// 解析qty字段
		req := struct {
			QTY float64 `json:"InOutQty"` // 数量
		}{}
		if json.Unmarshal([]byte(r.DETAILJSON), &req) == nil {
			r.QTY = req.QTY
		}
	}
}

func (r *Ermcp3AreaStockApply) buildSql() string {
	var sqlId utils.SQLVal = "SELECT to_char(t.operateapplyid) INOUTAPPLYID," +
		"       t.USERID," +
		"       t.operateapplytype INOUTTYPE," +
		"       t.WRSTANDARDID," +
		"       t.SPOTGOODSBRANDID," +
		"       t.DELIVERYGOODSID," +
		"       to_char(t.relatedid) SPOTCONTRACTID," +
		"       to_char(t.WAREHOUSEINFOID) WAREHOUSEINFOID," +
		"       to_char(t.detailjson) detailjson," +
		"       t.APPLYSTATUS," +
		"       t.APPLYSRC," +
		"       t.APPLYID," +
		"       t.remark APPLYREMARK," +
		"       to_char(t.APPLYTIME, 'yyyy-mm-dd hh24:mi:ss') APPLYTIME," +
		"       t.AUDITSRC," +
		"       t.AUDITID," +
		"       to_char(t.AUDITTIME, 'yyyy-mm-dd hh24:mi:ss') AUDITTIME," +
		"       t.AUDITREMARK," +
		"       t.AUDITTRADEDATE," +
		"       w.wrstandardname," +
		"       w.wrstandardcode," +
		"       g.goodsunitid unitid," +
		"       gb.dgfactoryitemvalue brandname," +
		"       h.warehousename," +
		"       h.warehousecode," +
		"       h.warehousetype," +
		"       s.contractno," +
		"       s.contracttype," +
		"       s.buyuserid," +
		"       s.selluserid," +
		"       s.pricetype," +
		"       s.qty CONTRACTQTY," +
		"       g.deliverygoodscode," +
		"       g.deliverygoodsname" +
		"  FROM ermcp_contractoperateapply t" +
		"  left join wrstandard w" +
		"    on t.wrstandardid = w.wrstandardid" +
		"  left join dgfactoryitem gb" +
		"    on t.spotgoodsbrandid = gb.dgfactoryitemid" +
		"  left join deliverygoods g" +
		"    on t.deliverygoodsid = g.deliverygoodsid" +
		"  left join warehouseinfo h" +
		"    on t.warehouseinfoid = h.autoid" +
		"  left join ermcp_spotcontract s" +
		"    on t.relatedid = s.spotcontractid" +
		" WHERE t.operateapplytype in(5,6,7,8)"

	areaUserId := mtpcache.GetAreaUserId(r.USERID, r.UserType)
	if areaUserId == r.USERID {
		// 机构用户
		sqlId.And("t.USERID", r.USERID)
	} else {
		if r.INOUTTYPE == 7 || r.INOUTTYPE == 8 {
			// 生产出入库, 没有相关合同
			sqlId.And("t.USERID", r.USERID)
		} else {
			sqlId.Join(fmt.Sprintf(" and %v in(s.saleuserid, s.tradeuserid, s.meruserid)", r.USERID))
		}
	}
	// 合同id
	sqlId.AndInterEx("t.RELATEDID", r.SPOTCONTRACTID, len(r.SPOTCONTRACTID) > 0)

	// 现货品种id
	if r.DELIVERYGOODSID > 0 {
		sqlId.And("t.DELIVERYGOODSID", r.DELIVERYGOODSID)
	}
	// 品类id
	if r.WRSTANDARDID > 0 {
		sqlId.And("t.WRSTANDARDID", r.WRSTANDARDID)
	}
	// 品牌id
	if r.SPOTGOODSBRANDID > 0 {
		sqlId.And("t.SPOTGOODSBRANDID", r.SPOTGOODSBRANDID)
	}
	// 仓库id
	sqlId.AndInterEx("t.WAREHOUSEINFOID", r.WAREHOUSEINFOID, len(r.WAREHOUSEINFOID) > 0)
	// 日期范围
	if len(r.BeginDate) > 0 {
		if r.BeginDate == r.EndDate {
			sqlId.And("t.tradedate", r.BeginDate)
		} else if r.EndDate > r.BeginDate {
			sqlId.BiggerOrEq("t.tradedate", r.BeginDate)
			sqlId.LessOrEq("t.tradedate", r.EndDate)
		}
	}
	// 出入库类型
	if len(r.FilterType) > 0 {

		// 原INOUTTYPE 1,2,3,4 转为 新表 5,6,7,8
		r.FilterType = strings.ReplaceAll(r.FilterType, "1", "5")
		r.FilterType = strings.ReplaceAll(r.FilterType, "2", "6")
		r.FilterType = strings.ReplaceAll(r.FilterType, "3", "7")
		r.FilterType = strings.ReplaceAll(r.FilterType, "4", "8")

		if len(r.FilterType) == 1 {
			sqlId.AndInterEx("t.OPERATEAPPLYTYPE", r.FilterType, true)
		} else {
			sqlId.Join(fmt.Sprintf(" and t.OPERATEAPPLYTYPE in(%v)", r.FilterType))
		}
	}
	// 出入库状态
	if len(r.FilterStatus) > 0 {
		sqlId.Join(fmt.Sprintf(" and t.APPLYSTATUS in(%v)", r.FilterStatus))
	}
	// 排序
	sqlId.Join(" order by t.APPLYTIME desc")
	return sqlId.String()
}

// GetDataEx 查询库存申请(记录)
func (r *Ermcp3AreaStockApply) GetDataEx() (interface{}, error) {
	sData := make([]Ermcp3AreaStockApply, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	if err == nil {
		for i := range sData {
			sData[i].calc()
		}
	}
	return sData, err
}

// Ermcp3AreaStockApplySum 合同出入库数量汇总
type Ermcp3AreaStockApplySum struct {
	INOUTTYPE        int32   `json:"inouttype"  xorm:"'INOUTTYPE'"`               // 出入库类型 - 5:采购入库 6:销售出库 7:生产入库 8:生产出库
	WRSTANDARDID     int32   `json:"wrstandardid"  xorm:"'WRSTANDARDID'"`         // 品类id
	SPOTGOODSBRANDID int32   `json:"spotgoodsbrandid"  xorm:"'SPOTGOODSBRANDID'"` // 品牌id
	BRANDNAME        string  `json:"brandname"  xorm:"'BRANDNAME'"`               // 品牌名称
	WRSTANDARDNAME   string  `json:"wrstandardname"  xorm:"'WRSTANDARDNAME'"`     // 品类名称
	TOTALQTY         float64 `json:"totalqty"  xorm:"'TOTALQTY'"`                 // 总数量
	SPOTCONTRACTID   string  `json:"spotcontractid"  xorm:"'relatedid'"`          // 关联现货合同ID
	DETAILJSON       string  `json:"-"  xorm:"'DETAILJSON'"`                      // 出入库数量
	Key              string  `json:"-"`                                           // 汇总主键
}

// Calc
func (r *Ermcp3AreaStockApplySum) Calc() {
	if len(r.DETAILJSON) > 0 {
		// 解析qty字段
		req := struct {
			QTY float64 `json:"InOutQty"` // 数量
		}{}
		if json.Unmarshal([]byte(r.DETAILJSON), &req) == nil {
			r.TOTALQTY = req.QTY
		}
	}

	r.Key = fmt.Sprintf("%v_%v_%v", r.INOUTTYPE, r.WRSTANDARDID, r.SPOTGOODSBRANDID)
}

func (r *Ermcp3AreaStockApplySum) buildSql() string {
	var sqlId utils.SQLVal = "select t.detailjson," +
		"       t.operateapplytype    INOUTTYPE," +
		"       t.wrstandardid," +
		"       t.relatedid," +
		"       t.spotgoodsbrandid," +
		"       gb.dgfactoryitemvalue brandname," +
		"       w.wrstandardcode," +
		"       w.wrstandardname" +
		"  from ermcp_contractoperateapply t" +
		"  left join dgfactoryitem gb" +
		"    on t.spotgoodsbrandid = gb.dgfactoryitemid" +
		"  left join wrstandard w" +
		"    on t.wrstandardid = w.wrstandardid" +
		" where t.operateapplytype in (5, 6)"
	sqlId.And("t.relatedid", r.SPOTCONTRACTID)
	return sqlId.String()
}

// GetDataEx 获取合同出入库汇总信息
func (r *Ermcp3AreaStockApplySum) GetDataEx() (interface{}, error) {
	sData := make([]Ermcp3AreaStockApplySum, 0)
	if err := db.GetEngine().SQL(r.buildSql()).Find(&sData); err == nil {
		mSum := map[string]Ermcp3AreaStockApplySum{}
		for i := range sData {
			sData[i].Calc()
			// 按品牌+品类+出入库类型 汇总
			if d, ok := mSum[sData[i].Key]; ok {
				d.TOTALQTY += sData[i].TOTALQTY
				mSum[sData[i].Key] = d
			} else {
				mSum[sData[i].Key] = sData[i]
			}
		}
		if len(mSum) > 0 {
			sData = make([]Ermcp3AreaStockApplySum, 0)
			for _, v := range mSum {
				sData = append(sData, v)
			}
		}
	}

	return sData, nil
}

// Ermcp3AreaStock 机构库存表
type Ermcp3AreaStock struct {
	TODAYBUYINQTY      float64 `json:"todaybuyinqty"  xorm:"'TODAYBUYINQTY'"`                    // 今日采购入库量
	TODAYPRODUCEINQTY  float64 `json:"todayproduceinqty"  xorm:"'TODAYPRODUCEINQTY'"`            // 今日生产入库量
	TODAYSELLOUTQTY    float64 `json:"todayselloutqty"  xorm:"'TODAYSELLOUTQTY'"`                // 今日销售出库量
	TODAYPRODUCEOUTQTY float64 `json:"todayproduceoutqty"  xorm:"'TODAYPRODUCEOUTQTY'"`          // 今日生产出库量
	UPDATETIME         string  `json:"updatetime"  xorm:"'UPDATETIME'"`                          // 更新时间
	USERID             int64   `json:"userid"  xorm:"'USERID'" form:"userid" binding:"required"` // 机构ID
	WRSTANDARDID       string  `json:"wrstandardid"  xorm:"'WRSTANDARDID'"`                      // 品类ID
	SPOTGOODSBRANDID   int32   `json:"spotgoodsbrandid"  xorm:"'SPOTGOODSBRANDID'"`              // 现货品牌ID
	WAREHOUSEINFOID    string  `json:"warehouseinfoid"  xorm:"'WAREHOUSEINFOID'"`                // 仓库ID
	ORISTOCK           float64 `json:"oristock"  xorm:"'ORISTOCK'"`                              // 期初库存量(昨日量)
	CURSTOCK           float64 `json:"curstock"  xorm:"'CURSTOCK'"`                              // 期末库存量(今日量)
	WRSTANDARDNAME     string  `json:"wrstandardname"  xorm:"'WRSTANDARDNAME'"`                  // 品类名称
	WRSTANDARDCODE     string  `json:"wrstandardcode"  xorm:"'WRSTANDARDCODE'"`                  // 品类代码
	UNITID             int32   `json:"unitid"  xorm:"'UNITID'"`                                  // 单位id
	BRANDNAME          string  `json:"brandname"  xorm:"'BRANDNAME'"`                            // 品牌名称
	WAREHOUSENAME      string  `json:"warehousename"  xorm:"'WAREHOUSENAME'"`                    // 仓库名称
	WAREHOUSECODE      string  `json:"warehousecode"  xorm:"'WAREHOUSECODE'"`                    // 仓库代码
	WAREHOUSETYPE      int32   `json:"warehousetype"  xorm:"'WAREHOUSETYPE'"`                    // 仓库类型 - 1 厂库  2 自有库  3 合作库
	USERNAME           string  `json:"username"`                                                 // 机构名称
	ENUMDICNAME        string  `json:"enumdicname"`                                              // 单位名称
	DELIVERYGOODSID    int32   `json:"deliverygoodsid"  xorm:"'DELIVERYGOODSID'"`                // 现货品种id
	DELIVERYGOODSCODE  string  `json:"deliverygoodscode"  xorm:"'DELIVERYGOODSCODE'"`            // 现货品种代码
	DELIVERYGOODSNAME  string  `json:"deliverygoodsname"  xorm:"'DELIVERYGOODSNAME'"`            // 现货品种名称
	GOODSUNITID        int32   `json:"goodsunitid"  xorm:"'GOODSUNITID'"`                        // 现货商品单位id
}

func (r *Ermcp3AreaStock) calc() {
	r.USERNAME = mtpcache.GetUserNameByUserId(r.USERID)
	r.ENUMDICNAME = mtpcache.GetEnumDicitemName(r.UNITID)
}

func (r *Ermcp3AreaStock) buildSql() string {
	var sqlId utils.SQLVal = "SELECT t.TODAYBUYINQTY," +
		"       t.TODAYPRODUCEINQTY," +
		"       t.TODAYSELLOUTQTY," +
		"       t.TODAYPRODUCEOUTQTY," +
		"       to_char(t.UPDATETIME, 'yyyy-mm-dd hh24:mi:ss') UPDATETIME," +
		"       t.USERID," +
		"       t.WRSTANDARDID," +
		"       t.SPOTGOODSBRANDID," +
		"       t.WAREHOUSEINFOID," +
		"       t.DELIVERYGOODSID," +
		"       t.ORISTOCK," +
		"       t.CURSTOCK," +
		"       w.wrstandardname," +
		"       w.wrstandardcode," +
		"       w.unitid," +
		"       gb.dgfactoryitemvalue brandname," +
		"       h.warehousename," +
		"       h.warehousecode," +
		"       h.warehousetype," +
		"       g.deliverygoodsid," +
		"       g.deliverygoodscode," +
		"       g.deliverygoodsname," +
		"       g.goodsunitid" +
		"  FROM ERMCP_AREASTOCK t" +
		"  LEFT JOIN WRSTANDARD w" +
		"    on t.wrstandardid = w.wrstandardid" +
		"  LEFT JOIN dgfactoryitem gb" +
		"    on t.spotgoodsbrandid = gb.dgfactoryitemid" +
		"  LEFT JOIN deliverygoods g" +
		"    on t.deliverygoodsid = g.deliverygoodsid" +
		"  LEFT JOIN WAREHOUSEINFO h" +
		"    on t.warehouseinfoid = h.autoid" +
		" WHERE 1 = 1"
	sqlId.And("t.USERID", r.USERID)
	sqlId.Join(" order by t.WRSTANDARDID, t.UPDATETIME desc")
	return sqlId.String()
}

// GetDataEx 获取机构库存信息
func (r *Ermcp3AreaStock) GetDataEx() (interface{}, error) {
	sData := make([]Ermcp3AreaStock, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	if err == nil {
		for i := range sData {
			sData[i].calc()
		}
	}
	return sData, err
}

// Ermcp3SpotGoodsPrice 现货市价
type Ermcp3SpotGoodsPrice struct {
	WRSTANDARDID      int64   `json:"wrstandardid"  xorm:"'WRSTANDARDID'"`           // 现货品类ID(通用则为0)
	SPOTGOODSBRANDID  int32   `json:"spotgoodsbrandid"  xorm:"'SPOTGOODSBRANDID'"`   // 现货品牌ID(通用则为0, 不为0则须先有品类ID)
	CURRENCYID        int32   `json:"currencyid"  xorm:"'CURRENCYID'"`               // 报价货币ID
	SPOTGOODSPRICE    float64 `json:"spotgoodsprice"  xorm:"'SPOTGOODSPRICE'"`       // 现货价格
	TRADEDATE         string  `json:"tradedate"  xorm:"'TRADEDATE'"`                 // 交易日(yyyyMMdd)
	OPERATESRC        int32   `json:"operatesrc"  xorm:"'OPERATESRC'"`               // 最后操作来源 - 1:管理端 2:终端
	OPERATEID         int64   `json:"operateid"  xorm:"'OPERATEID'"`                 // 最后操作人
	OPERATETIME       string  `json:"operatetime"  xorm:"'OPERATETIME'"`             // 最后操作时间
	ISVALID           int32   `json:"isvalid"  xorm:"'ISVALID'"`                     // 是否有效 - 0:无效 1:有效
	AREAUSERID        int64   `json:"areauserid"  xorm:"'AREAUSERID'"`               // 所属机构id
	WRSTANDARDCODE    string  `json:"wrstandardcode"  xorm:"'WRSTANDARDCODE'"`       // 品类代码
	WRSTANDARDNAME    string  `json:"wrstandardname"  xorm:"'WRSTANDARDNAME'"`       // 品类名称
	UNITID            int32   `json:"unitid"  xorm:"'UNITID'"`                       // 现货商品单位id
	BRANDNAME         string  `json:"brandname"  xorm:"'BRANDNAME'"`                 // 品牌名称
	GMUNITID          int32   `json:"gmunitid"  xorm:"'GMUNITID'"`                   // 品类单位id
	DELIVERYGOODSID   int32   `json:"deliverygoodsid"  xorm:"'DELIVERYGOODSID'"`     // 现货商品id
	DELIVERYGOODSCODE string  `json:"deliverygoodscode"  xorm:"'DELIVERYGOODSCODE'"` // 现货商品代码
	DELIVERYGOODSNAME string  `json:"deliverygoodsname"  xorm:"'DELIVERYGOODSNAME'"` // 现货商品名称

	OPERATORNAME  string `json:"operatorname"`  // 操作人名称
	ENUMDICNAME   string `json:"enumdicname"`   // 现货商品单位名称
	GBENUMDICNAME string `json:"gbenumdicname"` // 品类单位名称
	CURRENCYNAME  string `json:"currencyname"`  // 币种名称
}

func (r *Ermcp3SpotGoodsPrice) calc() {
	if r.OPERATESRC == 1 {
		r.OPERATORNAME = mtpcache.GetSystemmangerLoginCode(r.OPERATEID)
	} else {
		r.OPERATORNAME = mtpcache.GetLoginCodeByLoginId(r.OPERATEID)
	}
	r.ENUMDICNAME = mtpcache.GetEnumDicitemName(r.UNITID)
	r.GBENUMDICNAME = mtpcache.GetEnumDicitemName(r.GMUNITID)
	r.CURRENCYNAME = mtpcache.GetCurrencyName(r.CURRENCYID)
}

func (r *Ermcp3SpotGoodsPrice) buildSql() string {
	var sqlId utils.SQLVal = "SELECT t.WRSTANDARDID," +
		"       t.SPOTGOODSBRANDID," +
		"       t.CURRENCYID," +
		"       t.SPOTGOODSPRICE," +
		"       t.TRADEDATE," +
		"       t.OPERATESRC," +
		"       t.OPERATEID," +
		"       to_char(t.OPERATETIME, 'yyyy-mm-dd hh24:mi:ss') OPERATETIME," +
		"       t.ISVALID," +
		"       w.areauserid," +
		"       w.wrstandardcode," +
		"       w.wrstandardname," +
		"       w.unitid gmunitid," +
		"       gb.dgfactoryitemvalue brandname," +
		"       g.deliverygoodsid," +
		"       g.deliverygoodscode," +
		"       g.deliverygoodsname," +
		"       g.goodsunitid unitid" +
		"  FROM ERMCP_SPOTGOODSPRICE t" +
		"  left join wrstandard w" +
		"    on t.wrstandardid = w.wrstandardid" +
		"  left join dgfactoryitem gb" +
		"    on t.spotgoodsbrandid = gb.dgfactoryitemid" +
		"  left join deliverygoods g" +
		"    on t.deliverygoodsid = g.deliverygoodsid" +
		" WHERE 1 = 1"
	sqlId.And("w.areauserid", r.AREAUSERID)
	return sqlId.String()
}

// GetDataEx 获取现货市价
func (r *Ermcp3SpotGoodsPrice) GetDataEx() (interface{}, error) {
	sData := make([]Ermcp3SpotGoodsPrice, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	if err == nil {
		for i := range sData {
			sData[i].calc()
		}
	}
	return sData, err
}

// Ermcp3SpotGoodsPriceLog 现货市价操作日志
type Ermcp3SpotGoodsPriceLog struct {
	LOGID             int64   `json:"logid"  xorm:"'LOGID'"`                         // 日志id
	WRSTANDARDID      int64   `json:"wrstandardid"  xorm:"'WRSTANDARDID'"`           // 现货品类ID(通用则为0)
	SPOTGOODSBRANDID  int32   `json:"spotgoodsbrandid"  xorm:"'SPOTGOODSBRANDID'"`   // 现货品牌ID(通用则为0, 不为0则须先有品类ID)
	CURRENCYID        int64   `json:"currencyid"  xorm:"'CURRENCYID'"`               // 报价货币ID
	SPOTGOODSPRICE    float64 `json:"spotgoodsprice"  xorm:"'SPOTGOODSPRICE'"`       // 现货价格
	TRADEDATE         string  `json:"tradedate"  xorm:"'TRADEDATE'"`                 // 交易日(yyyyMMdd)
	OPERATESRC        int32   `json:"operatesrc"  xorm:"'OPERATESRC'"`               // 最后操作来源 - 1:管理端 2:终端
	OPERATEID         int64   `json:"operateid"  xorm:"'OPERATEID'"`                 // 最后操作人
	OPERATETIME       string  `json:"operatetime"  xorm:"'OPERATETIME'"`             // 最后操作时间
	AREAUSERID        int64   `json:"areauserid"  xorm:"'AREAUSERID'"`               // 所属机构id
	WRSTANDARDCODE    string  `json:"wrstandardcode"  xorm:"'WRSTANDARDCODE'"`       // 品类代码
	WRSTANDARDNAME    string  `json:"wrstandardname"  xorm:"'WRSTANDARDNAME'"`       // 品类名称
	UNITID            int32   `json:"unitid"  xorm:"'UNITID'"`                       // 现货商品单位id
	BRANDNAME         string  `json:"brandname"  xorm:"'BRANDNAME'"`                 // 品牌名称
	GMUNITID          int32   `json:"gmunitid"  xorm:"'GMUNITID'"`                   // 品类单位id
	DELIVERYGOODSID   int32   `json:"deliverygoodsid"  xorm:"'DELIVERYGOODSID'"`     // 现货商品id
	DELIVERYGOODSCODE string  `json:"deliverygoodscode"  xorm:"'DELIVERYGOODSCODE'"` // 现货商品代码
	DELIVERYGOODSNAME string  `json:"deliverygoodsname"  xorm:"'DELIVERYGOODSNAME'"` // 现货商品名称

	OPERATORNAME  string `json:"operatorname"`  // 操作人名称
	ENUMDICNAME   string `json:"enumdicname"`   // 现货商品单位名称
	GBENUMDICNAME string `json:"gbenumdicname"` // 品类单位名称
}

func (r *Ermcp3SpotGoodsPriceLog) calc() {
	if r.OPERATESRC == 1 {
		r.OPERATORNAME = mtpcache.GetSystemmangerLoginCode(r.OPERATEID)
	} else {
		r.OPERATORNAME = mtpcache.GetLoginCodeByLoginId(r.OPERATEID)
	}
	r.ENUMDICNAME = mtpcache.GetEnumDicitemName(r.UNITID)
	r.GBENUMDICNAME = mtpcache.GetEnumDicitemName(r.GMUNITID)
}

func (r *Ermcp3SpotGoodsPriceLog) buildSql() string {
	var sqlId utils.SQLVal = "SELECT t.WRSTANDARDID," +
		"       t.SPOTGOODSBRANDID," +
		"       t.CURRENCYID," +
		"       t.SPOTGOODSPRICE," +
		"       t.TRADEDATE," +
		"       t.OPERATESRC," +
		"       t.OPERATEID," +
		"       to_char(t.OPERATETIME, 'yyyy-mm-dd hh24:mi:ss') OPERATETIME," +
		"       t.LOGID," +
		"       w.areauserid," +
		"       w.wrstandardcode," +
		"       w.wrstandardname," +
		"       w.unitid gmunitid," +
		"       gb.dgfactoryitemvalue brandname," +
		"       g.goodsunitid unitid ," +
		"       g.deliverygoodsid," +
		"       g.deliverygoodscode," +
		"       g.deliverygoodsname" +
		"  FROM ERMCP_SPOTGOODSPRICELOG t" +
		"  left join wrstandard w" +
		"    on t.wrstandardid = w.wrstandardid" +
		"  left join dgfactoryitem gb" +
		"    on t.spotgoodsbrandid = gb.dgfactoryitemid" +
		"  left join deliverygoods g" +
		"    on t.deliverygoodsid = g.deliverygoodsid" +
		" WHERE 1 = 1"
	sqlId.And("w.areauserid", r.AREAUSERID)
	sqlId.And("t.deliverygoodsid", r.DELIVERYGOODSID)
	sqlId.AndEx("t.SPOTGOODSBRANDID", r.SPOTGOODSBRANDID, r.SPOTGOODSBRANDID > 0)
	sqlId.AndEx("t.wrstandardid", r.WRSTANDARDID, r.WRSTANDARDID > 0)
	return sqlId.String()
}

// GetDataEx 获取现货市价信息日志
func (r *Ermcp3SpotGoodsPriceLog) GetDataEx() (interface{}, error) {
	sData := make([]Ermcp3SpotGoodsPriceLog, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	if err == nil {
		for i := range sData {
			sData[i].calc()
		}
	}
	return sData, err
}

// Ermcp3HedgePlan 套保计划表结构
type Ermcp3HedgePlan struct {
	Areauserid        int64   `json:"areauserid"  xorm:"'Areauserid'"`               // 用户ID
	Hedgeplanid       string  `json:"hedgeplanid"  xorm:"'Hedgeplanid'"`             // 套保计划ID(601+Unix秒时间戳(10位)+xxxxxx)
	Hedgeplanno       string  `json:"hedgeplanno"  xorm:"'Hedgeplanno'"`             // 套保计划编号(名称)
	Contracttype      int     `json:"contracttype"  xorm:"'Contracttype'"`           // 计划类型 - 1:采购 -1:销售
	Deliverygoodsid   int     `json:"deliverygoodsid"  xorm:"'Deliverygoodsid'"`     // 现货品种ID
	Deliverygoodsname string  `json:"deliverygoodsname"  xorm:"'Deliverygoodsname'"` // 现货品种名称
	DELIVERYGOODSCODE string  `json:"deliverygoodscode"  xorm:"'DELIVERYGOODSCODE'"` // 现货品种代码
	Producttype       int     `json:"producttype"  xorm:"'Producttype'"`             // 产品类型 - 1:标准仓单 2:等标 3:非标
	Spotgoodsdesc     string  `json:"spotgoodsdesc"  xorm:"'Spotgoodsdesc'"`         // 商品型号
	Planqty           float64 `json:"planqty"  xorm:"'Planqty'"`                     // 计划数量
	Convertfactor     float64 `json:"convertfactor"  xorm:"'Convertfactor'"`         // 标仓系数
	Plantime          string  `json:"plantime"  xorm:"'Plantime'"`                   // 计划时间
	Hedgeplanstatus   int     `json:"hedgeplanstatus"  xorm:"'Hedgeplanstatus'"`     // 套保计划状态 -  0:未提交 1:待审核 2:执行中 3:正常完结 4:审核拒绝 5:异常完结 6:已撤回
	Remark            string  `json:"remark"  xorm:"'Remark'"`                       // 备注
	CREATETIME        string  `json:"createtime"  xorm:"'CREATETIME'"`               // 创建时间
	UPDATETIME        string  `json:"updatetime"  xorm:"'UPDATETIME'"`               // 更新时间
	AUDITTIME         string  `json:"audittime"  xorm:"'AUDITTIME'"`                 // 审核时间
	UNITID            int32   `json:"unitid"  xorm:"'UNITID'"`                       // 单位id(现货商品)
	ENUMDICNAME       string  `json:"enumdicname"`                                   // 单位名称(现货商品)
	WRSTANDARDID      int32   `json:"wrstandardid"  xorm:"'WRSTANDARDID'"`           // 品类id
	WRSTANDARDCODE    string  `json:"wrstandardcode"  xorm:"'WRSTANDARDCODE'"`       // 品类代码
	WRSTANDARDNAME    string  `json:"wrstandardname"  xorm:"'WRSTANDARDNAME'"`       // 品类名称
	ACCOUNTID         int64   `json:"accountid"  xorm:"'ACCOUNTID'"`                 // 资金账号
	TAACCOUNTNAME     string  `json:"taaccountname"  xorm:"'TAACCOUNTNAME'"`         // 资金账号名称
	TRADEUSERID       int64   `json:"tradeuserid"  xorm:"'TRADEUSERID'"`             // 交易用户id
	CURRENCYID        int32   `json:"currencyid"  xorm:"'CURRENCYID'"`               // 币种id
	WRUNITID          int32   `json:"wrunitid"  xorm:"'WRUNITID'"`                   // 品类单位id
	AUDITID           int64   `json:"auditid"  xorm:"'auditid'"`                     // 审核id
	AUDITSRC          int32   `json:"auditsrc"  xorm:"'AUDITSRC'"`                   // 审核来源 1-管理端 2-终端
	AUDITREMARK       string  `json:"auditremark"  xorm:"'auditremark'"`             // 审核备注
	AUDITNAME         string  `json:"auditname"  xorm:"'AUDITNAME'"`                 // 审核人名称

	WRUNITIDNAME  string `json:"wrunitidame"`   // 品类单位名称
	TRADEUSERNAME string `json:"tradeusername"` // 交易用户名称
	CURRENCYNAME  string `json:"currencyname"`  // 币种名称

	UserType int32 `json:"-"` // 过滤条件, 用户类型
}

func (r *Ermcp3HedgePlan) calc() {
	r.ENUMDICNAME = mtpcache.GetEnumDicitemName(r.UNITID)
	r.TRADEUSERNAME = mtpcache.GetUserNameByUserId(r.TRADEUSERID)
	r.CURRENCYNAME = mtpcache.GetCurrencyName(r.CURRENCYID)
	if r.WRUNITID > 0 {
		r.WRUNITIDNAME = mtpcache.GetEnumDicitemName(r.WRUNITID)
	}
	if r.AUDITSRC == 1 {
		if r.AUDITNAME == "" && r.AUDITID > 0 {
			r.AUDITNAME = mtpcache.GetSystemmangerLoginCode(r.AUDITID)
		}
	}
}

func (r *Ermcp3HedgePlan) buildSql(status string) string {
	str := "select to_char(t.Hedgeplanid) Hedgeplanid," +
		"       t.Hedgeplanno," +
		"       t.Contracttype," +
		"       t.Deliverygoodsid," +
		"       g.Deliverygoodsname," +
		"       g.deliverygoodscode," +
		"       g.goodsunitid unitid," +
		"       t.Producttype," +
		"       t.Spotgoodsdesc," +
		"       t.Planqty," +
		"       t.Convertfactor," +
		"       to_char(t.Plantime, 'yyyy-mm-dd hh24:mi:ss') Plantime," +
		"       to_char(t.createtime, 'yyyy-mm-dd hh24:mi:ss') createtime," +
		"       to_char(t.updatetime, 'yyyy-mm-dd hh24:mi:ss') updatetime," +
		"       to_char(t.audittime, 'yyyy-mm-dd hh24:mi:ss') audittime," +
		"       t.Hedgeplanstatus," +
		"       t.Remark," +
		"       t.wrstandardid," +
		"       w.wrstandardcode," +
		"       w.wrstandardname," +
		"       w.unitid wrunitid," +
		"       t.accountid," +
		"       t.tradeuserid," +
		"       t.currencyid," +
		"       t.auditid," +
		"       t.auditsrc," +
		"       t.auditremark," +
		"       ta.accountname taaccountname," +
		"       l.accountname auditname" +
		"  from ermcp_hedgeplan t" +
		"  left join deliverygoods g" +
		"    on t.deliverygoodsid = g.deliverygoodsid" +
		"  left join wrstandard w" +
		"    on t.wrstandardid = w.wrstandardid" +
		"  left join taaccount ta" +
		"    on t.accountid = ta.accountid" +
		"  left join loginaccount l on t.auditid=l.loginid" +
		" where t.hedgeplanstatus in (%v)"

	if r.UserType == 0 {
		// 终端没传值, 则自己去找
		userId := mtpcache.GetAreaUserId(r.Areauserid, 0)
		if userId == r.Areauserid {
			r.UserType = 2
		} else {
			r.UserType = 7
		}
	}

	if r.UserType == 2 {
		str += "   and t.areauserid = %v"
	} else if r.UserType == 7 {
		// 企业成员用tradeuserid匹配
		str += "   and t.tradeuserid = %v"
	} else {
		str += "   and t.areauserid = %v"
	}

	if status == "2" {
		// 执行中状态，按审核时间倒序
		str += " order by t.audittime desc"
	} else {
		str += " order by t.updatetime desc"
	}

	return fmt.Sprintf(str, status, r.Areauserid)
}

// GetData 从数据库中查询套保计划数据
func (r *Ermcp3HedgePlan) GetData(status string) ([]Ermcp3HedgePlan, error) {
	e := db.GetEngine()
	sData := make([]Ermcp3HedgePlan, 0)
	if err := e.SQL(r.buildSql(status)).Find(&sData); err != nil {
		logger.GetLogger().Errorf("query hedgeplan:%v", err)
		return sData, err
	}
	for i := range sData {
		sData[i].calc()
	}

	return sData, nil
}

// Ermcp3GoodsGroup 商品组
type Ermcp3GoodsGroup struct {
	GOODSGROUPID       int32   `json:"goodsgroupid"  xorm:"'GOODSGROUPID'"`             // 商品组ID(自增ID)
	GOODSGROUPNAME     string  `json:"goodsgroupname"  xorm:"'GOODSGROUPNAME'"`         // 商品组名称
	GOODSGROUPSTATUS   int32   `json:"goodsgroupstatus"  xorm:"'GOODSGROUPSTATUS'"`     // 商品组状态 - 1:正常 2:注销
	MARKETID           int32   `json:"marketid"  xorm:"'MARKETID'"`                     // 所属市场ID
	CREATETIME         string  `json:"createtime"  xorm:"'CREATETIME'"`                 // 创建时间
	CREATORID          int32   `json:"creatorid"  xorm:"'CREATORID'"`                   // 创建人
	MODIFYTIME         string  `json:"modifytime"  xorm:"'MODIFYTIME'"`                 // 修改时间
	MODIFIERID         int32   `json:"modifierid"  xorm:"'MODIFIERID'"`                 // 修改人
	QUOTESOURCEGROUPID int64   `json:"quotesourcegroupid"  xorm:"'QUOTESOURCEGROUPID'"` // 所属行情源分组ID[参考行情市场用\通道交易]
	OUTERGROUPCODE     string  `json:"outergroupcode"  xorm:"'OUTERGROUPCODE'"`         // 外部商品组代码[通道交易]
	CANSHORT           int32   `json:"canshort"  xorm:"'CANSHORT'"`                     // 是否允许做空[通道交易] - 0:不能做空 1:可以做空
	EXEXCHANGEID       int64   `json:"exexchangeid"  xorm:"'EXEXCHANGEID'"`             // 外部交易所ID[通道交易]
	CURRENCYID         int32   `json:"currencyid"  xorm:"'CURRENCYID'"`                 // 报价货币ID
	GOODUNITID         int32   `json:"goodunitid"  xorm:"'GOODUNITID'"`                 // 报价单位ID
	AGREEUNIT          float32 `json:"agreeunit"  xorm:"'AGREEUNIT'"`                   // 合约单位
	DECIMALPLACE       int32   `json:"decimalplace"  xorm:"'DECIMALPLACE'"`             // 报价小数位
	QUOTEMINUNIT       int32   `json:"quoteminunit"  xorm:"'QUOTEMINUNIT'"`             // 行情最小变动单位 [整数，报价小数位一起使用]
	INNERDEALMODE      int32   `json:"innerdealmode"  xorm:"'INNERDEALMODE'"`           // 内部成交方式[通道交易] - 1:净头寸 2:开平 3:平今
	OUTERDEALMODE      int32   `json:"outerdealmode"  xorm:"'OUTERDEALMODE'"`           // 外部成交方式[通道交易]- 1:净头寸 2:开平 3:平今
	SYNCGOODSQTY       int32   `json:"syncgoodsqty"  xorm:"'SYNCGOODSQTY'"`             // 同步合约数[通道交易-投资管理用] - 0表示不限
	CLOSEPRICEMODE     int32   `json:"closepricemode"  xorm:"'CLOSEPRICEMODE'"`         // 强平价格方式 - 1:市价 2:最新价 3:涨跌停（未实现）
	GROUPCATEGROYID    int32   `json:"groupcategroyid"  xorm:"'GROUPCATEGROYID'"`       // 品种分类ID
	EXEXCHANGECODE     string  `json:"exexchangecode"  xorm:"'EXEXCHANGECODE'"`         // 交易所代码
	EXEXCHANGENAME     string  `json:"exexchangename"  xorm:"'EXEXCHANGENAME'"`         // 交易所名称
	EXCHANGEFULLNAME   string  `json:"exchangefullname"  xorm:"'EXCHANGEFULLNAME'"`     // 交易所全称

	ENUMDICNAME string `json:"enumdicname"`                                     // 单位名称
	AreaUserId  int64  `json:"areauserid" form:"areauserid" binding:"required"` // 所属机构id(套保品是有areauserid的,当要排除已配置商品组时需要areauserid过滤)
	ExcludeCfg  int32  `json:"excludecfg" form:"excludecfg"`                    // 排除套保品已配置期货分类下的商品组(但显示已配置商品组) 1-排除
}

func (r *Ermcp3GoodsGroup) calc() {
	r.ENUMDICNAME = mtpcache.GetEnumDicitemName(r.GOODUNITID)
}

func (r *Ermcp3GoodsGroup) buildSql() string {
	var sqlId utils.SQLVal = "SELECT t.GOODSGROUPID," +
		"       t.GOODSGROUPNAME," +
		"       t.GOODSGROUPSTATUS," +
		"       t.MARKETID," +
		"       to_char(t.CREATETIME, 'yyyy-mm-dd hh24:mi:ss') CREATETIME," +
		"       t.CREATORID," +
		"       to_char(t.MODIFYTIME, 'yyyy-mm-dd hh24:mi:ss') MODIFYTIME," +
		"       t.MODIFIERID," +
		"       t.QUOTESOURCEGROUPID," +
		"       t.OUTERGROUPCODE," +
		"       t.CANSHORT," +
		"       t.EXEXCHANGEID," +
		"       t.CURRENCYID," +
		"       t.GOODUNITID," +
		"       t.AGREEUNIT," +
		"       t.DECIMALPLACE," +
		"       t.QUOTEMINUNIT," +
		"       t.INNERDEALMODE," +
		"       t.OUTERDEALMODE," +
		"       t.SYNCGOODSQTY," +
		"       t.CLOSEPRICEMODE," +
		"       t.GROUPCATEGROYID," +
		"       e.exexchangecode," +
		"       e.exexchangename," +
		"       e.exchangefullname" +
		"  FROM GOODSGROUP t" +
		"  LEFT JOIN market m" +
		"    on t.marketid = m.marketid" +
		"  LEFT JOIN externalexchange e on t.exexchangeid=e.autoid" +
		" WHERE 1 = 1" +
		"   and m.trademode = 15"
	if r.ExcludeCfg == 1 {
		str := "select t.goodsgroupid" +
			"  from ERMS_MiddleGoods t" +
			" where t.isvalid=1 and t.areauserid = %v" +
			" union all " +
			"select goodsgroupid" +
			"  from goodsgroup t" +
			" where t.groupcategroyid not in" +
			"       (select distinct g.groupcategroyid" +
			"          from erms_middlegoods t" +
			"          left join goodsgroup g" +
			"            on t.goodsgroupid = g.goodsgroupid" +
			"         where t.isvalid=1 and t.areauserid = %v)"
		str = fmt.Sprintf(str, r.AreaUserId, r.AreaUserId)
		sqlId.Join(fmt.Sprintf(" and t.goodsgroupid in(%v)", str))
	}
	return sqlId.String()
}

// GetData
func (r *Ermcp3GoodsGroup) GetData() ([]Ermcp3GoodsGroup, error) {
	sData := make([]Ermcp3GoodsGroup, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// GetDataEx 商品组信息
func (r *Ermcp3GoodsGroup) GetDataEx() (interface{}, error) {
	return r.GetData()
}

// Ermcp3RootUserAccount 顶级用户
type Ermcp3RootUserAccount struct {
	ROOTUSERID       int64  `json:"rootuserid"  xorm:"ROOTUSERID"`             // 根用户ID
	CANRECOMMEND     int32  `json:"canrecommend"  xorm:"CANRECOMMEND"`         // 是否可推荐 - 0:不可 1;可
	USERID           int64  `json:"userid"  xorm:"USERID"`                     // 用户ID
	USERTYPE         int32  `json:"usertype"  xorm:"USERTYPE"`                 // 账户类型 -  1:交易所 2:机构 3:会员子机构 4:经纪人 5:投资者 6:客户 7:企业成员(云平台)
	MODIFYSTATUS     int32  `json:"modifystatus"  xorm:"MODIFYSTATUS"`         // 变更状态 1 未变更 2 变更中 3 变更待审核 4 变更待复核(投资者)
	ACCOUNTNAME      string `json:"accountname"  xorm:"ACCOUNTNAME"`           // 账户名称(机构名称)
	PARENTUSERID     int64  `json:"parentuserid"  xorm:"PARENTUSERID"`         // 所属机构ID
	BROKER           int64  `json:"broker"  xorm:"BROKER"`                     // 所属经纪人ID
	SUBAREALEVELPATH string `json:"subarealevelpath"  xorm:"SUBAREALEVELPATH"` // 子机构层级路径(逗号分隔,首尾加逗号)
	REFEREEUSERID    int64  `json:"refereeuserid"  xorm:"REFEREEUSERID"`       // 推荐人ID
	MEMBERUSERID     int64  `json:"memberuserid"  xorm:"MEMBERUSERID"`         // 所属会员ID
	ACCOUNTSTATUS    int32  `json:"accountstatus"  xorm:"ACCOUNTSTATUS"`       // 账户状态 -  1:待激活 2:待审核 3:待复审 4:正常 5:审核拒绝 6:停用(注销) 7:注销(删除)
	RECKONACCOUNTID  int64  `json:"reckonaccountid"  xorm:"RECKONACCOUNTID"`   // 默认结算资金账号ID(机构分润使用) 作废
	CREATETIME       string `json:"createtime"  xorm:"CREATETIME"`             // 创建时间
	CREATORID        int64  `json:"creatorid"  xorm:"CREATORID"`               // 创建人
	AUDITTIME        string `json:"audittime"  xorm:"AUDITTIME"`               // 审核时间
	AUDITUSERID      int64  `json:"audituserid"  xorm:"AUDITUSERID"`           // 审核人
	AUDITREMARK      string `json:"auditremark"  xorm:"AUDITREMARK"`           // 审核备注
	CANCELTIME       string `json:"canceltime"  xorm:"CANCELTIME"`             // 销户时间
	CANCELUSERID     int64  `json:"canceluserid"  xorm:"CANCELUSERID"`         // 销户人
	MODIFYTIME       string `json:"modifytime"  xorm:"MODIFYTIME"`             // 修改时间
	MODIFIERID       int64  `json:"modifierid"  xorm:"MODIFIERID"`             // 修改人
	MODIFYREMARK     string `json:"modifyremark"  xorm:"MODIFYREMARK"`         // 变更备注
	MAXINVESTORNUM   int64  `json:"maxinvestornum"  xorm:"MAXINVESTORNUM"`     // 最大用户数(经纪会员下投资者个数)
	HASAUTH          int32  `json:"hasauth"  xorm:"HASAUTH"`                   // 是否已实名认证 - 0:未认证 1:已认证 2:已提交(待审核) 3:已拒绝
	REFERCOUNT       int32  `json:"refercount"  xorm:"REFERCOUNT"`             // 推荐总人数
	REFERNUM         string `json:"refernum"  xorm:"REFERNUM"`                 // 推荐码
	ISANONYMOUS      int32  `json:"isanonymous"  xorm:"ISANONYMOUS"`           // 是否匿名下单 - 0:否 1:是
	PARENTTOPUSER    string `json:"parenttopuser"  xorm:"PARENTTOPUSER"`       // 上级顶级机构 [092=0,1时，默认为1， 092=2时若自已为顶级，则填入自己，自己不为顶级，填入ParentUserID的"ParentTopUser"]
	SUBACCOUNTLEVEL  int32  `json:"subaccountlevel"  xorm:"SUBACCOUNTLEVEL"`   // 子账户层数
	APPLYSRC         int32  `json:"applysrc"  xorm:"APPLYSRC"`                 // 申请来源 - 1:管理端 2:终端
	AUDITSRC         int32  `json:"auditsrc"  xorm:"AUDITSRC"`                 // 审核来源 - 1:管理端 2:终端
}

func (r *Ermcp3RootUserAccount) calc() {

}

func (r *Ermcp3RootUserAccount) buildSql() string {
	var sqlId utils.SQLVal = "SELECT t.ROOTUSERID," +
		"       t.CANRECOMMEND," +
		"       t.USERID," +
		"       t.USERTYPE," +
		"       t.MODIFYSTATUS," +
		"       t.ACCOUNTNAME," +
		"       t.PARENTUSERID," +
		"       t.BROKER," +
		"       t.SUBAREALEVELPATH," +
		"       t.REFEREEUSERID," +
		"       t.MEMBERUSERID," +
		"       t.ACCOUNTSTATUS," +
		"       t.RECKONACCOUNTID," +
		"       to_char(t.CREATETIME, 'yyyy-mm-dd hh24:mi:ss') CREATETIME," +
		"       t.CREATORID," +
		"       to_char(t.AUDITTIME, 'yyyy-mm-dd hh24:mi:ss') AUDITTIME," +
		"       t.AUDITUSERID," +
		"       t.AUDITREMARK," +
		"       to_char(t.CANCELTIME, 'yyyy-mm-dd hh24:mi:ss') CANCELTIME," +
		"       t.CANCELUSERID," +
		"       to_char(t.MODIFYTIME, 'yyyy-mm-dd hh24:mi:ss') MODIFYTIME," +
		"       t.MODIFIERID," +
		"       t.MODIFYREMARK," +
		"       t.MAXINVESTORNUM," +
		"       t.HASAUTH," +
		"       t.REFERCOUNT," +
		"       t.REFERNUM," +
		"       t.ISANONYMOUS," +
		"       t.PARENTTOPUSER," +
		"       t.SUBACCOUNTLEVEL," +
		"       t.APPLYSRC," +
		"       t.AUDITSRC" +
		"  FROM USERACCOUNT t" +
		" WHERE 1 = 1 and t.userid in(select rootuserid from useraccount where userid=%v)"
	sqlId.FormatParam(r.USERID)
	return sqlId.String()
}

// GetDataEx 获取顶级用户
func (r *Ermcp3RootUserAccount) GetDataEx() (interface{}, error) {
	sData := make([]Ermcp3RootUserAccount, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// Ermcp3PaAreaSubject 交易主体
type Ermcp3PaAreaSubject struct {
	SUBJECTID       int64  `json:"subjectid"  xorm:"SUBJECTID" form:"subjectid"`                   // 主体ID(SEQ_ERMCP_PA_AREASUBJECT)
	SUBJECTTYPE     int32  `json:"subjecttype"  xorm:"SUBJECTTYPE"`                                // 主体类型 - 1:交易主体 2:业务部门
	SUBJECTNAME     string `json:"subjectname"  xorm:"SUBJECTNAME"`                                // 主体名称
	PARENTSUBJECTID string `json:"parentsubjectid"  xorm:"PARENTSUBJECTID" form:"parentsubjectid"` // 上级主体ID
	AREAUSERID      int64  `json:"areauserid"  xorm:"AREAUSERID" form:"userid"`                    // 所属机构
	CREATETIME      string `json:"createtime"  xorm:"CREATETIME"`                                  // 创建时间
	CREATORSRC      int32  `json:"creatorsrc"  xorm:"CREATORSRC"`                                  // 创建人来源 - 1:管理端 2:终端 3:交易
	CREATORID       string `json:"creatorid"  xorm:"CREATORID" form:"creatorid"`                   // 创建人ID
	MODIFIERSRC     int32  `json:"modifiersrc"  xorm:"MODIFIERSRC"`                                // 修改人来源 - 1:管理端 2:终端
	MODIFIERID      string `json:"modifierid"  xorm:"MODIFIERID" form:"modifierid"`                // 修改人
	MODIFYTIME      string `json:"modifytime"  xorm:"MODIFYTIME"`                                  // 修改时间
	SUBJECTSTATUS   int32  `json:"subjectstatus"  xorm:"SUBJECTSTATUS"`                            // 主体状态 - 1:正常 2: 停用
	CANMODIFY       int32  `json:"canmodify"  xorm:"CANMODIFY"`                                    // 是否可修改 - 0:否 1:是
	REMARK          string `json:"remark"  xorm:"REMARK"`                                          // 备注
}

func (r *Ermcp3PaAreaSubject) calc() {

}

func (r *Ermcp3PaAreaSubject) buildSql() string {
	var sqlId utils.SQLVal = `
SELECT t.SUBJECTID,
       t.SUBJECTTYPE,
       t.SUBJECTNAME,
       t.PARENTSUBJECTID,
       t.AREAUSERID,
       to_char(t.CREATETIME, 'yyyy-mm-dd hh24:mi:ss') CREATETIME,
       t.CREATORSRC,
       t.CREATORID,
       t.MODIFIERSRC,
       t.MODIFIERID,
       to_char(t.MODIFYTIME, 'yyyy-mm-dd hh24:mi:ss') MODIFYTIME,
       t.SUBJECTSTATUS,
       t.CANMODIFY,
       t.REMARK
  FROM ERMCP_PA_AREASUBJECT t
 WHERE 1 = 1
`
	areaUserId := mtpcache.GetAreaUserId(r.AREAUSERID, 0)
	sqlId.And("t.AREAUSERID", areaUserId)
	sqlId.AndEx("t.SUBJECTID", r.SUBJECTID, r.SUBJECTID > 0)
	sqlId.AndEx("t.SUBJECTTYPE", r.SUBJECTTYPE, r.SUBJECTTYPE > 0)
	sqlId.AndEx("t.SUBJECTSTATUS", r.SUBJECTSTATUS, r.SUBJECTSTATUS > 0)
	return sqlId.String()
}

// GetDataEx 获取交易主体
func (r *Ermcp3PaAreaSubject) GetDataEx() (interface{}, error) {
	sData := make([]Ermcp3PaAreaSubject, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// Ermcp3PaAreaAuditCfg 审核设置
type Ermcp3PaAreaAuditCfg struct {
	AREAUSERID            int64  `json:"areauserid"  xorm:"AREAUSERID" form:"serid"`          // 用户ID
	CUSTOMERAUDITFLAG     int32  `json:"customerauditflag"  xorm:"CUSTOMERAUDITFLAG"`         // 客户资料是否需要审核 - 0:不需审核 1:需要审核
	SPOTCONTRACTAUDITFLAG int32  `json:"spotcontractauditflag"  xorm:"SPOTCONTRACTAUDITFLAG"` // 现货合同是否需要审核 - 0:不需审核 1:需要审核
	POINTPRICEAUDITFLAG   int32  `json:"pointpriceauditflag"  xorm:"POINTPRICEAUDITFLAG"`     // 点价是否需要审核 - 0:不需审核 1:需要审核
	DELIVERYAUDITFLAG     int32  `json:"deliveryauditflag"  xorm:"DELIVERYAUDITFLAG"`         // 交收是否需要审核 - 0:不需审核 1:需要审核
	MONEYAUDITFLAG        int32  `json:"moneyauditflag"  xorm:"MONEYAUDITFLAG"`               // 款项是否需要审核 - 0:不需审核 1:需要审核
	INVOICEAUDITFLAG      int32  `json:"invoiceauditflag"  xorm:"INVOICEAUDITFLAG"`           // 发票是否需要审核 - 0:不需审核 1:需要审核
	BUYINAUDITFLAG        int32  `json:"buyinauditflag"  xorm:"BUYINAUDITFLAG"`               // 采购入库是否需要审核 - 0:不需审核 1:需要审核
	SELLOUTAUDITFLAG      int32  `json:"selloutauditflag"  xorm:"SELLOUTAUDITFLAG"`           // 销售出库是否需要审核 - 0:不需审核 1:需要审核
	PRODUCEINAUDITFLAG    int32  `json:"produceinauditflag"  xorm:"PRODUCEINAUDITFLAG"`       // 生产入库是否需要审核 - 0:不需审核 1:需要审核
	PRODUCEOUTAUDITFLAG   int32  `json:"produceoutauditflag"  xorm:"PRODUCEOUTAUDITFLAG"`     // 生产出库是否需要审核 - 0:不需审核 1:需要审核
	OPERATORSRC           int32  `json:"operatorsrc"  xorm:"OPERATORSRC"`                     // 操作来源 - 1:管理端 2:终端
	OPERATORID            int64  `json:"operatorid"  xorm:"OPERATORID" form:"operatorid"`     // 操作人
	UPDATETIME            string `json:"updatetime"  xorm:"UPDATETIME"`                       // 更新时间
}

func (r *Ermcp3PaAreaAuditCfg) calc() {

}

func (r *Ermcp3PaAreaAuditCfg) buildSql() string {
	var sqlId utils.SQLVal = `
SELECT t.AREAUSERID,
       t.CUSTOMERAUDITFLAG,
       t.SPOTCONTRACTAUDITFLAG,
       t.POINTPRICEAUDITFLAG,
       t.DELIVERYAUDITFLAG,
       t.MONEYAUDITFLAG,
       t.INVOICEAUDITFLAG,
       t.BUYINAUDITFLAG,
       t.SELLOUTAUDITFLAG,
       t.PRODUCEINAUDITFLAG,
       t.PRODUCEOUTAUDITFLAG,
       t.OPERATORSRC,
       t.OPERATORID,
       to_char(t.UPDATETIME, 'yyyy-mm-dd hh24:mi:ss') UPDATETIME
  FROM ERMCP_PA_AREAAUDITCONFIG t
 WHERE 1 = 1
`
	areaUserId := mtpcache.GetAreaUserId(r.AREAUSERID, 0)
	sqlId.And("t.AREAUSERID", areaUserId)
	return sqlId.String()
}

// GetDataEx 获取审核设置
func (r *Ermcp3PaAreaAuditCfg) GetDataEx() (interface{}, error) {
	sData := make([]Ermcp3PaAreaAuditCfg, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// XHDeliveryGoods 商品信息-现货品种
type XHDeliveryGoods struct {
	AREAUSERID        int64  `json:"areauserid"  xorm:"'AREAUSERID'" form:"areauserid"`                // 所属机构
	DELIVERYGOODSID   int64  `json:"deliverygoodsid"  xorm:"'DELIVERYGOODSID'" form:"deliverygoodsid"` // 现货品种ID(SEQ_DELIVERYGOODS)
	DELIVERYGOODSCODE string `json:"deliverygoodscode"  xorm:"'DELIVERYGOODSCODE'"`                    // 现货品种代码
	DELIVERYGOODSNAME string `json:"deliverygoodsname"  xorm:"'DELIVERYGOODSNAME'"`                    // 现货品种名称
	ISVALID           int32  `json:"isvalid"  xorm:"'ISVALID'"`                                        // 是否有效 - 0:无效 1:有效
	DGSTATUS          int32  `json:"dgstatus"  xorm:"'DGSTATUS'"`                                      // 品种状态 - 作废 - 0:未激活 1:正常
	REMARK            string `json:"remark"  xorm:"'REMARK'"`                                          // 备注

	WDLST []XHWrstandard `json:"wdlst"` // 品类(现货商品)列表
	BDLST []XHBRAND      `json:"bdlst"` // 品牌列表
}

func (r *XHDeliveryGoods) calc() {
	if r.WDLST == nil {
		r.WDLST = make([]XHWrstandard, 0)
		r.BDLST = make([]XHBRAND, 0)
	}
}

func (r *XHDeliveryGoods) buildSql() string {
	var sqlId utils.SQLVal = `
SELECT t.AREAUSERID,
       t.DELIVERYGOODSID,
       t.DELIVERYGOODSCODE,
       t.DELIVERYGOODSNAME,
       t.ISVALID,
       t.DGSTATUS,
       t.REMARK
  FROM DELIVERYGOODS t
 WHERE 1 = 1
`
	sqlId.AndEx("t.AREAUSERID", r.AREAUSERID, r.AREAUSERID > 0)
	sqlId.AndEx("t.DELIVERYGOODSID", r.DELIVERYGOODSID, r.DELIVERYGOODSID > 0)
	return sqlId.String()
}

// GetDataEx 获取商品信息-现货品种
func (r *XHDeliveryGoods) GetDataEx() (interface{}, error) {
	sData := make([]XHDeliveryGoods, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}

	if len(sData) > 0 {
		// 获取品类列表
		m1 := XHWrstandard{AREAUSERID: r.AREAUSERID, DELIVERYGOODSID: r.DELIVERYGOODSID}
		if d1, err := m1.GetDataEx(); err == nil {
			lstWd := d1.([]XHWrstandard)
			for i := range sData {
				sData[i].addWdlst(lstWd)
			}
		}

		// 获取品牌列表
		m2 := XHBRAND{DELIVERYGOODSID: r.DELIVERYGOODSID, AREAUSERID: r.AREAUSERID}
		if d2, err := m2.GetDataEx(); err == nil {
			lstBrand := d2.([]XHBRAND)
			for i := range sData {
				sData[i].addBrandlst(lstBrand)
			}
		}
	}

	return sData, err
}

// 增加品类列表
func (r *XHDeliveryGoods) addWdlst(lstWd []XHWrstandard) {
	for i := range lstWd {
		if lstWd[i].DELIVERYGOODSID == r.DELIVERYGOODSID {
			r.WDLST = append(r.WDLST, lstWd[i])
		}
	}
}

// 增加品牌列表
func (r *XHDeliveryGoods) addBrandlst(lstBrand []XHBRAND) {
	for i := range lstBrand {
		if lstBrand[i].DELIVERYGOODSID == r.DELIVERYGOODSID {
			r.BDLST = append(r.BDLST, lstBrand[i])
		}
	}
}

// XHBRAND 现货品种/品牌
type XHBRAND struct {
	BRANDID         int64  `json:"brandid"`   // 品牌id
	BRANDNAME       string `json:"brandname"` // 品牌名称
	DELIVERYGOODSID int64  `json:"-"`         // 品种ID
	AREAUSERID      int64  `json:"-"`         // 用户id
}

// GetDataEx 获取现货品种/品牌
func (r *XHBRAND) GetDataEx() (interface{}, error) {
	sData := make([]XHBRAND, 0)
	m := Ermcp3Brand{AREAUSERID: r.AREAUSERID, DELIVERYGOODSID: r.DELIVERYGOODSID}
	d, err := m.GetData()
	if err == nil {
		for _, v := range d {
			sData = append(sData, XHBRAND{DELIVERYGOODSID: v.DELIVERYGOODSID, BRANDID: v.BRANDID, BRANDNAME: v.BRANDNAME})
		}
	}
	return sData, err
}

// XHWrstandard 现货品种/品类
type XHWrstandard struct {
	AREAUSERID      int64   `json:"-"  xorm:"'AREAUSERID'" form:"areauserid"`                         // 所属机构
	DELIVERYGOODSID int64   `json:"deliverygoodsid"  xorm:"'DELIVERYGOODSID'" form:"deliverygoodsid"` // 品种ID
	WRSTANDARDID    int64   `json:"wrstandardid"  xorm:"'WRSTANDARDID'"`                              // 现货商品ID(SEQ_WRSTANDARD)
	WRSTANDARDCODE  string  `json:"wrstandardcode"  xorm:"'WRSTANDARDCODE'"`                          // 现货商品代码
	WRSTANDARDNAME  string  `json:"wrstandardname"  xorm:"'WRSTANDARDNAME'"`                          // 现货商品名称
	VATRATE         float64 `json:"vatrate"  xorm:"'VATRATE'"`                                        // 增值税率
	ENUMDICNAME     string  `json:"enumdicname"  xorm:"'ENUMDICNAME'"`                                // 单位名称

	MGLST []XHMiddleGoods `json:"mglst"` // 套保品列表
}

func (r *XHWrstandard) calc() {
	if r.MGLST == nil {
		r.MGLST = make([]XHMiddleGoods, 0)
	}
}

func (r *XHWrstandard) buildSql() string {
	var sqlId utils.SQLVal = `
select t.areauserid,
       t.deliverygoodsid,
       t.wrstandardid,
       t.wrstandardcode,
       t.wrstandardname,
       t.vatrate,
       e.enumdicname
  from wrstandard t
  left join enumdicitem e
    on t.unitid = e.enumitemname
   and e.enumdiccode = 'goodsunit'
 where 1 = 1
`
	sqlId.AndEx("t.AREAUSERID", r.AREAUSERID, r.AREAUSERID > 0)
	sqlId.AndEx("t.DELIVERYGOODSID", r.DELIVERYGOODSID, r.DELIVERYGOODSID > 0)
	return sqlId.String()
}

// GetDataEx 获取现货品种/品类
func (r *XHWrstandard) GetDataEx() (interface{}, error) {
	sData := make([]XHWrstandard, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}

	if len(sData) > 0 {
		// 获取套保品列表
		m := XHMiddleGoods{AREAUSERID: r.AREAUSERID, WRSTANDARDID: r.WRSTANDARDID}
		if d, err := m.GetDataEx(); err == nil {
			lstMidd := d.([]XHMiddleGoods)
			for i := range sData {
				sData[i].addMgLst(lstMidd)
			}
		}
	}

	return sData, err
}

func (r *XHWrstandard) addMgLst(midd []XHMiddleGoods) {
	for i := range midd {
		if r.WRSTANDARDID == midd[i].WRSTANDARDID {
			r.MGLST = append(r.MGLST, midd[i])
		}
	}
}

// XHMiddleGoods 现货品种/品类/套保品
type XHMiddleGoods struct {
	AREAUSERID      int64   `json:"-"  xorm:"'AREAUSERID'" form:"areauserid"`     // 所属机构
	WRSTANDARDID    int64   `json:"-"  xorm:"'WRSTANDARDID'" form:"wrstandardid"` // 现货商品ID(SEQ_WRSTANDARD)
	CONVERTRATIO    float64 `json:"convertratio"  xorm:"'CONVERTRATIO'"`          // 拆算系数
	MIDDLEGOODSID   int64   `json:"middlegoodsid"  xorm:"'MIDDLEGOODSID'"`        // 套保品种id
	MIDDLEGOODSCODE string  `json:"middlegoodscode"  xorm:"'MIDDLEGOODSCODE'"`    // 套保品种代码
	MIDDLEGOODSNAME string  `json:"middlegoodsname"  xorm:"'MIDDLEGOODSNAME'"`    // 套保品种名称
	ENUMDICNAME     string  `json:"enumdicname"  xorm:"'ENUMDICNAME'"`            // 单位名称
}

func (r *XHMiddleGoods) calc() {

}

func (r *XHMiddleGoods) buildSql() string {
	var sqlId utils.SQLVal = `
select w.wrstandardid,
       c.convertratio,
       m.areauserid,
       m.middlegoodsid,
       m.middlegoodscode,
       m.middlegoodsname,
       e.enumdicname
  from wrstandard w
 inner join erms2_wrsconvertdetail c
    on w.wrstandardid = c.wrstandardid
 inner join erms_middlegoods m
    on c.middlegoodsid = m.middlegoodsid
  left join enumdicitem e
    on m.goodsunitid = e.enumitemname
   and e.enumdiccode = 'goodsunit'
 where 1 = 1 and w.isvalid = 1
`
	sqlId.AndEx("m.areauserid", r.AREAUSERID, r.AREAUSERID > 0)
	sqlId.AndEx("w.WRSTANDARDID", r.WRSTANDARDID, r.WRSTANDARDID > 0)
	return sqlId.String()
}

// GetDataEx 获取现货品种/品类/套保品
func (r *XHMiddleGoods) GetDataEx() (interface{}, error) {
	sData := make([]XHMiddleGoods, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// TBMiddleGoods 商品信息-套保品种
type TBMiddleGoods struct {
	AREAUSERID         int64   `json:"areauserid"  xorm:"'AREAUSERID'" form:"areauserid"`          // 机构用户ID
	MIDDLEGOODSID      int64   `json:"middlegoodsid"  xorm:"'MIDDLEGOODSID'" form:"middlegoodsid"` // 套保品种ID(SEQ_ERMS_MIDDLEGOODS)
	MIDDLEGOODSCODE    string  `json:"middlegoodscode"  xorm:"'MIDDLEGOODSCODE'"`                  // 套保品种代码
	MIDDLEGOODSNAME    string  `json:"middlegoodsname"  xorm:"'MIDDLEGOODSNAME'"`                  // 套保品种名称
	NEEDHEDGERATIO     float64 `json:"needhedgeratio"  xorm:"'NEEDHEDGERATIO'"`                    // 套保比率
	NEEDARBITRAGERATIO float64 `json:"needarbitrageratio"  xorm:"'NEEDARBITRAGERATIO'"`            // 套利比率
	GOODSGROUPID       int64   `json:"-"  xorm:"'GOODSGROUPID'"`                                   // 关联期货商品组id
	ENUMDICNAME        string  `json:"enumdicname"  xorm:"'ENUMDICNAME'"`                          // 单位名称

	GPLST []TBGoodsGroup // 期货品种列表
	WDLST []TBWrstandard // 商品信息列表(现货品类)
}

func (r *TBMiddleGoods) calc() {
	r.GPLST = make([]TBGoodsGroup, 0)
	r.WDLST = make([]TBWrstandard, 0)
}

func (r *TBMiddleGoods) buildSql() string {
	var sqlId utils.SQLVal = `
select t.areauserid,
       t.middlegoodsid,
       t.middlegoodscode,
       t.middlegoodsname,
       t.needhedgeratio,
       t.needarbitrageratio,
       t.goodsgroupid,
       e.enumdicname
  from erms_middlegoods t
  left join enumdicitem e
    on t.goodsunitid = e.enumitemname
   and e.enumdiccode = 'goodsunit'
 where 1 = 1 and t.isvalid=1
`
	sqlId.AndEx("t.areauserid", r.AREAUSERID, r.AREAUSERID > 0)
	sqlId.AndEx("t.middlegoodsid", r.MIDDLEGOODSID, r.MIDDLEGOODSID > 0)
	return sqlId.String()
}

// GetDataEx 获取商品信息-套保品种
func (r *TBMiddleGoods) GetDataEx() (interface{}, error) {
	sData := make([]TBMiddleGoods, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	if len(sData) > 0 {
		// 获取关联期货品种
		m1 := TBGoodsGroup{}
		if d1, err := m1.GetDataEx(); err == nil {
			gpLst := d1.([]TBGoodsGroup)
			for i := range sData {
				sData[i].addGpLst(gpLst)
			}
		}

		// 获取关联现货商品
		m2 := TBWrstandard{}
		if d2, err := m2.GetDataEx(); err == nil {
			wdLst := d2.([]TBWrstandard)
			for i := range sData {
				sData[i].addWdLst(wdLst)
			}
		}
	}
	return sData, err
}

func (r *TBMiddleGoods) addGpLst(lst []TBGoodsGroup) {
	for i := range lst {
		if r.GOODSGROUPID == lst[i].DESTGOODSGROUPID {
			r.GPLST = append(r.GPLST, lst[i])
		}
	}
}

func (r *TBMiddleGoods) addWdLst(lst []TBWrstandard) {
	for i := range lst {
		if r.MIDDLEGOODSID == lst[i].MIDDLEGOODSID {
			r.WDLST = append(r.WDLST, lst[i])
		}
	}
}

// TBGoodsGroup 套保品种/期货品种
type TBGoodsGroup struct {
	GOODSGROUPID     int64     `json:"goodsgroupid"  xorm:"'GOODSGROUPID'"`     // 商品组ID(自增ID)
	GOODSGROUPNAME   string    `json:"goodsgroupname"  xorm:"'GOODSGROUPNAME'"` // 商品组名称
	GOODUNITID       int32     `json:"goodunitid"  xorm:"'GOODUNITID'"`         // 报价单位ID
	CONVERTRATIO     float64   `json:"convertratio"  xorm:"'CONVERTRATIO'"`     // 折算系数
	DESTGOODSGROUPID int64     `json:"-"  xorm:"'DESTGOODSGROUPID'"`            // 目标商品组id
	EXEXCHANGECODE   string    `json:"exexchangecode"  xorm:"'EXEXCHANGECODE'"` // 交易所代码
	EXEXCHANGENAME   string    `json:"exexchangename"  xorm:"'EXEXCHANGENAME'"` // 交易所名称
	ENUMDICNAME      string    `json:"enumdicname"  xorm:"'ENUMDICNAME'"`       // 单位名称
	GDLST            []TBGoods // 商品列表
}

func (r *TBGoodsGroup) calc() {
	r.GDLST = make([]TBGoods, 0)
}

func (r *TBGoodsGroup) buildSql() string {
	var sqlId utils.SQLVal = `
select t.goodsgroupid,
       t.goodsgroupname,
       t.goodunitid,
       c.convertratio,
       c.destgoodsgroupid,
       ex.exexchangecode,
       ex.exexchangename,
       e.enumdicname
  from goodsgroup t
  inner join ermcp_ggconvertconfig c
    on t.goodsgroupid = c.srcgoodsgroupid
  left join externalexchange ex on t.exexchangeid=ex.autoid
  left join enumdicitem e
    on t.goodunitid = e.enumitemname
   and e.enumdiccode = 'goodsunit'
 where 1 = 1 and t.goodsgroupstatus=1
`

	return sqlId.String()
}

// GetDataEx 获取套保品种/期货品种
func (r *TBGoodsGroup) GetDataEx() (interface{}, error) {
	sData := make([]TBGoodsGroup, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	if len(sData) > 0 {
		// 获取关联商品
		m := TBGoods{}
		if d, err := m.GetDataEx(); err == nil {
			gdLst := d.([]TBGoods)
			for i := range sData {
				sData[i].addGdLst(gdLst)
			}
		}
	}
	return sData, err
}

func (r *TBGoodsGroup) addGdLst(lst []TBGoods) {
	for i := range lst {
		if r.GOODSGROUPID == lst[i].GOODSGROUPID {
			r.GDLST = append(r.GDLST, lst[i])
		}
	}
}

// TBGoods 套保品种/期货品种/期货合约
type TBGoods struct {
	GOODSID      int64   `json:"goodsid"  xorm:"'GOODSID'"`         // 商品ID(自增ID SEQ_GOODS)
	GOODSCODE    string  `json:"goodscode"  xorm:"'GOODSCODE'"`     // 商品代码(内部)
	GOODSNAME    string  `json:"goodsname"  xorm:"'GOODSNAME'"`     // 商品名称
	GOODSGROUPID int64   `json:"-"  xorm:"'GOODSGROUPID'"`          // 所属商品组ID
	AGREEUNIT    float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`     // 合约乘数
	ENUMDICNAME  string  `json:"enumdicname"  xorm:"'ENUMDICNAME'"` // 单位名称
}

func (r *TBGoods) calc() {

}

func (r *TBGoods) buildSql() string {
	var sqlId utils.SQLVal = `
select t.goodsid,
       t.goodscode,
       t.goodsname,
       t.goodsgroupid,
       t.agreeunit,
       e.enumdicname
  from goods t
  left join enumdicitem e
    on t.goodunitid = e.enumitemname
   and e.enumdiccode = 'goodsunit'
 where 1 = 1
   and t.goodsstatus not in (4, 5, 6)
   and t.goodsgroupid in
       (select srcgoodsgroupid from ermcp_ggconvertconfig)
`

	return sqlId.String()
}

// GetDataEx 获取套保品种/期货品种/期货合约
func (r *TBGoods) GetDataEx() (interface{}, error) {
	sData := make([]TBGoods, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// TBWrstandard 套保品种/商品信息(现货商品)
type TBWrstandard struct {
	WRSTANDARDID      int64   `json:"wrstandardid"  xorm:"'WRSTANDARDID'"`           // 现货商品ID(SEQ_WRSTANDARD)
	WRSTANDARDCODE    string  `json:"wrstandardcode"  xorm:"'WRSTANDARDCODE'"`       // 现货商品代码
	WRSTANDARDNAME    string  `json:"wrstandardname"  xorm:"'WRSTANDARDNAME'"`       // 现货商品名称
	DELIVERYGOODSID   int64   `json:"-"  xorm:"'DELIVERYGOODSID'"`                   // 品种ID
	VATRATE           float64 `json:"vatrate"  xorm:"'VATRATE'"`                     // 增值税率
	DELIVERYGOODSNAME string  `json:"deliverygoodsname"  xorm:"'DELIVERYGOODSNAME'"` // 品种名称
	CONVERTRATIO      float64 `json:"convertratio"  xorm:"'CONVERTRATIO'"`           // 折算系数
	MIDDLEGOODSID     int64   `json:"-"  xorm:"'MIDDLEGOODSID'"`                     // 品种id
	ENUMDICNAME       string  `json:"enumdicname"  xorm:"'ENUMDICNAME'"`             // 单位名称
}

func (r *TBWrstandard) calc() {

}

func (r *TBWrstandard) buildSql() string {
	var sqlId utils.SQLVal = `
select t.wrstandardid,
       t.wrstandardcode,
       t.wrstandardname,
       t.deliverygoodsid,
       t.vatrate,
       g.deliverygoodsname,
       c.convertratio,
       c.middlegoodsid,
       e.enumdicname
  from wrstandard t
  left join deliverygoods g
    on t.deliverygoodsid = g.deliverygoodsid
 inner join erms2_wrsconvertdetail c
    on t.wrstandardid = c.wrstandardid
  left join enumdicitem e
    on t.unitid = e.enumitemname
   and e.enumdiccode = 'goodsunit'
 where 1 = 1 and t.isvalid=1
 order by c.middlegoodsid
`

	return sqlId.String()
}

// GetDataEx 获取套保品种/商品信息(现货商品)
func (r *TBWrstandard) GetDataEx() (interface{}, error) {
	sData := make([]TBWrstandard, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}