MTP20_IF/models/hsby.go

package models

import (
	"encoding/hex"
	"fmt"
	"math"
	"mtp2_if/db"
	"mtp2_if/pb"
	"mtp2_if/utils"
	"strconv"
	"strings"
	"time"

	"google.golang.org/protobuf/proto"
)

// Hsbygoodsex 商品扩展表
type Hsbygoodsex struct {
	Goodsid        int32     `json:"goodsid"  xorm:"'GOODSID'" binding:"required"` // 商 品ID
	Hotindex       int32     `json:"hotindex"  xorm:"'HOTINDEX'"`                  // 景点热度
	Descprovinceid int64     `json:"descprovinceid"  xorm:"'DESCPROVINCEID'"`      // 目的地(省)
	Desccityid     int64     `json:"desccityid"  xorm:"'DESCCITYID'"`              // 目的地(市)
	Vendorid       int32     `json:"vendorid"  xorm:"'VENDORID'"`                  // 供应商ID
	Goodsdesc      string    `json:"goodsdesc"  xorm:"'GOODSDESC'"`                // 商品详情
	Createtime     time.Time `json:"createtime"  xorm:"'CREATETIME'"`              // 创建时间
	Creatorid      int64     `json:"creatorid"  xorm:"'CREATORID'"`                // 创建人
	Modifierid     int64     `json:"modifierid"  xorm:"'MODIFIERID'"`              // 修改人
	Modifytime     time.Time `json:"modifytime"  xorm:"'MODIFYTIME'"`              // 修改时间
	Memberratio    float64   `json:"memberratio"  xorm:"'MEMBERRATIO'"`            // 会员货款比例 [71]
	Videourls      string    `json:"videourls"  xorm:"'VIDEOURLS'"`                // 介绍视频[多张用逗号分隔]
	Picurls        string    `json:"picurls"  xorm:"'PICURLS'"`                    // 介绍图片[多张用逗号分隔]
	Goodsprice     float64   `json:"goodsprice"  xorm:"'GOODSPRICE'"`              // 商品价格
	Categoryid     int32     `json:"categoryid"  xorm:"'CATEGORYID'"`              // 类别ID(WRCATEGORY)
}

// TableName is HSBY_GOODSEX
func (Hsbygoodsex) TableName() string {
	return "HSBY_GOODSEX"
}

// Hsbysupplierinfo 供应商表
type Hsbysupplierinfo struct {
	Vendorid    int32     `json:"vendorid"  xorm:"'VENDORID'" binding:"required"` // 供应商ID(SEQ_HSBY_SUPPLIERINFO)
	Vendorname  string    `json:"vendorname"  xorm:"'VENDORNAME'"`                // 名称描述客服电话名称
	Vendordesc  string    `json:"vendordesc"  xorm:"'VENDORDESC'"`                // 描述
	Vendorphone string    `json:"vendorphone"  xorm:"'VENDORPHONE'"`              // 客服电话
	Vendorattr  string    `json:"vendorattr"  xorm:"'VENDORATTR'"`                // 附件(多张，逗号分隔)
	Createtime  time.Time `json:"createtime"  xorm:"'CREATETIME'"`                // 创建时间
	Creatorid   int64     `json:"creatorid"  xorm:"'CREATORID'"`                  // 创建人
	Modifierid  int64     `json:"modifierid"  xorm:"'MODIFIERID'"`                // 修改人
	Modifytime  time.Time `json:"modifytime"  xorm:"'MODIFYTIME'"`                // 修改时间
}

// TableName is HSBY_SUPPLIERINFO
func (Hsbysupplierinfo) TableName() string {
	return "HSBY_SUPPLIERINFO"
}

// Tradepayorder 交易待付款表
type Tradepayorder struct {
	Tradeid        int64     `json:"tradeid"  xorm:"'TRADEID'" binding:"required"` // 成交单号(101+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	Tradedate      string    `json:"tradedate"  xorm:"'TRADEDATE'"`                // 交易日(yyyyMMdd)
	Marketid       int32     `json:"marketid"  xorm:"'MARKETID'"`                  // 市场ID
	Goodsid        int32     `json:"goodsid"  xorm:"'GOODSID'"`                    // 商品ID
	Buyorderid     int64     `json:"buyorderid"  xorm:"'BUYORDERID'"`              // 买方委托单号
	Buyaccountid   int64     `json:"buyaccountid"  xorm:"'BUYACCOUNTID'"`          // 买方账号ID[报价币种]
	Sellorderid    int64     `json:"sellorderid"  xorm:"'SELLORDERID'"`            // 卖方委托单号
	Sellaccountid  int64     `json:"sellaccountid"  xorm:"'SELLACCOUNTID'"`        // 卖方账号ID[报价币种]
	Tradeamount    float64   `json:"tradeamount"  xorm:"'TRADEAMOUNT'"`            // 成交金额
	Tradecharge    float64   `json:"tradecharge"  xorm:"'TRADECHARGE'"`            // 成交手续费(买方)
	Payflag        int32     `json:"payflag"  xorm:"'PAYFLAG'"`                    // 付款标识 - 1:未支付 2:已支付 3:已过期 4:已撤销 5:结算过期 6:预售终止
	Createtime     time.Time `json:"createtime"  xorm:"'CREATETIME'"`              // 创建时间
	Paytime        time.Time `json:"paytime"  xorm:"'PAYTIME'"`                    // 付款时间
	Paylimitedtime time.Time `json:"paylimitedtime"  xorm:"'PAYLIMITEDTIME'"`      // 支付期限
	Offamount      float64   `json:"offamount"  xorm:"'OFFAMOUNT'"`                // 优惠金额
	Tradeprice     float64   `json:"tradeprice"  xorm:"'TRADEPRICE'"`              // 成交价格
	Tradeqty       int64     `json:"tradeqty"  xorm:"'TRADEQTY'"`                  // 成交数量
	Payamount      float64   `json:"payamount"  xorm:"'PAYAMOUNT'"`                // 支付金额 = TradeAmount + TradeCharge - OffAmount
}

// TableName is TRADE_PAYORDER
func (Tradepayorder) TableName() string {
	return "TRADE_PAYORDER"
}

// Coupontype 优惠券类型表
type Coupontype struct {
	Coupontypeid    int32     `json:"coupontypeid"  xorm:"'COUPONTYPEID'" binding:"required"` // 优惠券类型ID - SEQ_COUPONTYPE
	Areauserid      int64     `json:"areauserid"  xorm:"'AREAUSERID'"`                        // 所属机构
	Couponname      string    `json:"couponname"  xorm:"'COUPONNAME'"`                        // 优惠券名称
	Couponcategroy  int32     `json:"couponcategroy"  xorm:"'COUPONCATEGROY'"`                // 种类 - 1:现金券 2:折扣券 3:折扣券(单张)
	Conditionvalue  float64   `json:"conditionvalue"  xorm:"'CONDITIONVALUE'"`                // 条件阈值(可为0)
	Couponvalue     float64   `json:"couponvalue"  xorm:"'COUPONVALUE'"`                      // 面值[1:现金券 - 抵扣值 2:折扣券-折扣值]
	Limitedflag     int32     `json:"limitedflag"  xorm:"'LIMITEDFLAG'"`                      // 是否指定商品 - 0:不限 1:限制
	Limitedgoodsids string    `json:"limitedgoodsids"  xorm:"'LIMITEDGOODSIDS'"`              // 指定商品IDs[逗号分隔,前后加逗号]
	Isgeneral       int32     `json:"isgeneral"  xorm:"'ISGENERAL'"`                          // 是否通用券 - 0:否 1:是
	Userscope       string    `json:"userscope"  xorm:"'USERSCOPE'"`                          // 卖家范围(用户ID，逗号分隔,前后加逗号) [IsGeneral =0时使用]
	Qty             int64     `json:"qty"  xorm:"'QTY'"`                                      // 数量
	Curqty          int64     `json:"curqty"  xorm:"'CURQTY'"`                                // 剩余数量
	Createtime      time.Time `json:"createtime"  xorm:"'CREATETIME'"`                        // 创建时间
	Creatorid       int64     `json:"creatorid"  xorm:"'CREATORID'"`                          // 创建人
	Modifierid      int64     `json:"modifierid"  xorm:"'MODIFIERID'"`                        // 修改人
	Modifytime      time.Time `json:"modifytime"  xorm:"'MODIFYTIME'"`                        // 修改时间
	Usedqty         int64     `json:"usedqty"  xorm:"'USEDQTY'"`                              // 使用量
	Isvalid         int32     `json:"isvalid"  xorm:"'ISVALID'"`                              // 是否有效 - 0:无效 1:有效
	Expiredqty      int64     `json:"expiredqty"  xorm:"'EXPIREDQTY'"`                        // 失效量
}

// TableName is COUPONTYPE
func (Coupontype) TableName() string {
	return "COUPONTYPE"
}

// Couponposition 优惠券头寸表 - 导历史(期末为0的清除)
type Couponposition struct {
	Accountid     int64 `json:"accountid"  xorm:"'ACCOUNTID'" binding:"required"`       // 资金账户ID
	Coupontypeid  int32 `json:"coupontypeid"  xorm:"'COUPONTYPEID'" binding:"required"` // 优惠券类型ID
	Userid        int64 `json:"userid"  xorm:"'USERID'"`                                // 用户ID
	Oriqty        int64 `json:"oriqty"  xorm:"'ORIQTY'"`                                // 期初数量
	Orifreezeqty  int64 `json:"orifreezeqty"  xorm:"'ORIFREEZEQTY'"`                    // 期初冻结数量
	Curqty        int64 `json:"curqty"  xorm:"'CURQTY'"`                                // 期末数量
	Curfreezeqty  int64 `json:"curfreezeqty"  xorm:"'CURFREEZEQTY'"`                    // 期末冻结数量
	Todayincrease int64 `json:"todayincrease"  xorm:"'TODAYINCREASE'"`                  // 今日增加
	Todaydecrease int64 `json:"todaydecrease"  xorm:"'TODAYDECREASE'"`                  // 今日减少
}

// TableName is COUPONPOSITION
func (Couponposition) TableName() string {
	return "COUPONPOSITION"
}

// Couponhold 优惠券持仓表 - 导历史(不清当前表) - 每一个数量一条记录
type Couponhold struct {
	Couponholdid    int64     `json:"couponholdid"  xorm:"'COUPONHOLDID'" binding:"required"` // 优惠券持仓ID(229+Unix秒时间戳(10位)+xxxxxx)
	Giveapplyid     int64     `json:"giveapplyid"  xorm:"'GIVEAPPLYID'"`                      // 发放申请ID(SEQ_COUPONGIVEAPPLY)
	Accountid       int64     `json:"accountid"  xorm:"'ACCOUNTID'"`                          // 资金账户ID
	Coupontypeid    int32     `json:"coupontypeid"  xorm:"'COUPONTYPEID'"`                    // 优惠券类型ID - SEQ_COUPONTYPE
	Couponcategroy  int32     `json:"couponcategroy"  xorm:"'COUPONCATEGROY'"`                // 种类 - 1:现金券 2:折扣券 3:折扣券(单个商品)
	Conditionvalue  float64   `json:"conditionvalue"  xorm:"'CONDITIONVALUE'"`                // 条件阈值(可为0)
	Couponvalue     float64   `json:"couponvalue"  xorm:"'COUPONVALUE'"`                      // 面值[1:现金券 - 抵扣值 2:折扣券-折扣值]
	Limitedflag     int32     `json:"limitedflag"  xorm:"'LIMITEDFLAG'"`                      // 是否指定商品 - 0:不限 1:限制
	Limitedgoodsids string    `json:"limitedgoodsids"  xorm:"'LIMITEDGOODSIDS'"`              // 指定商品IDs[逗号分隔]
	Isgeneral       int32     `json:"isgeneral"  xorm:"'ISGENERAL'"`                          // 是否通用券 - 0:否 1:是
	Userscope       string    `json:"userscope"  xorm:"'USERSCOPE'"`                          // 卖家范围(用户ID，逗号分隔) [IsGeneral =0时使用]
	Userid          int64     `json:"userid"  xorm:"'USERID'"`                                // 用户ID
	Qty             int64     `json:"qty"  xorm:"'QTY'"`                                      // 数量(按1平铺)
	Startdate       time.Time `json:"startdate"  xorm:"'STARTDATE'"`                          // 开始日期
	Holdstatus      int32     `json:"holdstatus"  xorm:"'HOLDSTATUS'"`                        // 持仓状态 - 1:未生效 2:已生效 3:已使用 4:已过期
	Enddate         time.Time `json:"enddate"  xorm:"'ENDDATE'"`                              // 结束日期
	Createtime      time.Time `json:"createtime"  xorm:"'CREATETIME'"`                        // 创建时间
}

// TableName is COUPONHOLD
func (Couponhold) TableName() string {
	return "COUPONHOLD"
}

// Tradeordercoupon 交易委托优惠券表
type Tradeordercoupon struct {
	Orderid        string    `json:"orderid"  xorm:"'ORDERIDSTR'" binding:"required"`           // 委托单号(100+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	Coupontypeid   string    `json:"coupontypeid"  xorm:"'COUPONTYPEIDSTR'" binding:"required"` // 优惠券类型ID(买方)
	Accountid      int64     `json:"accountid"  xorm:"'ACCOUNTID'"`                             // 资金账户ID(买方)
	Usedqty        int64     `json:"usedqty"  xorm:"'USEDQTY'"`                                 // 使用数量
	Couponcategroy int32     `json:"couponcategroy"  xorm:"'COUPONCATEGROY'"`                   // 种类 - 1:现金券 2:折扣券
	Conditionvalue float64   `json:"conditionvalue"  xorm:"'CONDITIONVALUE'"`                   // 条件阈值(可为0)
	Couponvalue    float64   `json:"couponvalue"  xorm:"'COUPONVALUE'"`                         // 面值[1:现金券 - 抵扣值 2:折扣券-折扣值(0-100)]
	Sellaccountid  int64     `json:"sellaccountid"  xorm:"'SELLACCOUNTID'"`                     // 资金账户ID(卖方)
	Marketid       int32     `json:"marketid"  xorm:"'MARKETID'"`                               // 市场ID
	Goodsid        int32     `json:"goodsid"  xorm:"'GOODSID'"`                                 // 商品ID
	Tradeid        string    `json:"tradeid"  xorm:"'TRADEIDSTR'"`                              // 成交单号(101+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	Tradeamount    float64   `json:"tradeamount"  xorm:"'TRADEAMOUNT'"`                         // 成交金额
	Offamount      float64   `json:"offamount"  xorm:"'OFFAMOUNT'"`                             // 优惠金额
	Handlestatus   int32     `json:"handlestatus"  xorm:"'HANDLESTATUS'"`                       // 处理状态
	Createtime     time.Time `json:"createtime"  xorm:"'CREATETIME'"`                           // 创建时间
}

// TableName is TRADE_ORDERCOUPON
func (Tradeordercoupon) TableName() string {
	return "TRADE_ORDERCOUPON"
}

// HsbyTopGoods 热卖商品（二级市场挂牌点选）
type HsbyTopGoods struct {
	Goodsid      int64   `json:"goodsid"  xorm:"'GOODSID'" binding:"required"`     // 商品ID(自增ID SEQ_GOODS)
	Goodscode    string  `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string  `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64   `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Marketid     int64   `json:"marketid"  xorm:"'MARKETID'" binding:"required"`   // 所属市场ID
	Quoteminunit int64   `json:"quoteminunit"  xorm:"'QUOTEMINUNIT'"`              // 行情最小变动单位 [整数，报价小数位一起使用]
	Agreeunit    float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位

	Hotindex  int32  `json:"hotindex"  xorm:"'HOTINDEX'"`   // 景点热度
	Videourls string `json:"videourls"  xorm:"'VIDEOURLS'"` // 介绍视频[多张用逗号分隔]
	Picurls   string `json:"picurls"  xorm:"'PICURLS'"`     // 介绍图片[多张用逗号分隔]

	Currency     string `json:"currency" xorm:"'CURRENCY'"`         // 货币
	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号

	Trademode int32 `json:"trademode"  xorm:"'TRADEMODE'" binding:"required"` // 交易模式 - 10:做市 13:竞价 15:通道交易 16:挂牌点选 17:仓单贸易 18:期权 19:竞拍-降价式 20:竞拍-竞价式 21:竞拍-大宗式 22:受托竞价

	Last float64 `json:"last" xorm:"-"` // 现价
}

// GetHsbyTopGoodses 获取热门商品列表
// 参数 marketIDs string 所属市场ID列表, 格式 1,2,3
// 参数 descProvinceID int 目标省ID
// 参数 descCityID int 目标城市ID
// 返回 []TopGoods 热门商品列表
// 返回 error error
func GetHsbyTopGoodses(marketIDs string, descProvinceID, descCityID int) ([]HsbyTopGoods, error) {
	// 热门商品为二级市场（挂牌点选）下的商品信息

	engine := db.GetEngine()

	topGoodses := make([]HsbyTopGoods, 0)
	// 获取挂牌商品信息，以及扩展表信息
	// 与商城不一样的是，挂牌点选以商品表作为主表，同一商品可有多个委托单
	session := engine.Table("GOODS").
		Select(`GOODS.*, 
				HSBY_GOODSEX.HOTINDEX, HSBY_GOODSEX.VIDEOURLS, HSBY_GOODSEX.PICURLS, 
				ENUMDICITEM.ENUMDICNAME CURRENCY, ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				MARKET.TRADEMODE`).
		Join("LEFT", "HSBY_GOODSEX", "HSBY_GOODSEX.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "ENUMDICITEM.ENUMITEMNAME = GOODS.CURRENCYID and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET", "MARKET.MARKETID = GOODS.MARKETID").
		Where(fmt.Sprintf("GOODS.GOODSSTATUS = 3 and GOODS.MARKETID in (%s)", marketIDs)) // 二级市场只获取 3:上市 状态的商品
	if descProvinceID > 0 {
		session = session.And("HSBY_GOODSEX.DESCPROVINCEID = ?", descProvinceID)
	}
	if descCityID > 0 {
		session = session.And("HSBY_GOODSEX.DESCCITYID = ?", descCityID)
	}
	if err := session.Find(&topGoodses); err != nil {
		return nil, err
	}
	if len(topGoodses) == 0 {
		// 无数据
		return topGoodses, nil
	}
	// 获取商品ID列表
	goodsCodes := ""
	for _, v := range topGoodses {
		if len(goodsCodes) == 0 {
			goodsCodes = v.Goodscode
		} else {
			goodsCodes += "," + v.Goodscode
		}
	}

	// 获取商品现价
	quoteDays, err := GetQuoteDays(goodsCodes)
	if err != nil {
		return nil, err
	}
	for i, g := range topGoodses {
		topGoods := &topGoodses[i]
		// FIXME: - 这里应该使用 Duck Typing，后期再处理
		// 计算最小变动单位
		// lotSize := float64(topGoods.Quoteminunit) * math.Pow(0.1, float64(topGoods.Decimalplace))
		// topGoods.LotSize, _ = strconv.ParseFloat(utils.FormatFloat(lotSize, int(topGoods.Decimalplace)), 64)

		for _, q := range quoteDays {
			if g.Goodscode == q.Goodscode {
				if q.Last != 0 {
					topGoods.Last = utils.IntToFloat64(int(q.Last), int(g.Decimalplace))
				}
				// 没有现价则尝试用昨结
				if topGoods.Last == 0 && q.Presettle != 0 {
					topGoods.Last = utils.IntToFloat64(int(q.Presettle), int(g.Decimalplace))
				}

				continue
			}
		}
	}

	return topGoodses, nil
}

// HsbyListingGoodsDetail 二级市场（挂牌点选）商品信息详情
type HsbyListingGoodsDetail struct {
	Goodsid      int64   `json:"goodsid"  xorm:"'GOODSID'" binding:"required"`     // 商品ID(自增ID SEQ_GOODS)
	Goodscode    string  `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string  `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64   `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Marketid     int64   `json:"marketid"  xorm:"'MARKETID'" binding:"required"`   // 所属市场ID
	Quoteminunit int64   `json:"quoteminunit"  xorm:"'QUOTEMINUNIT'"`              // 行情最小变动单位 [整数，报价小数位一起使用]
	Agreeunit    float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位

	Hotindex       int32   `json:"hotindex"  xorm:"'HOTINDEX'"`             // 景点热度
	Videourls      string  `json:"videourls"  xorm:"'VIDEOURLS'"`           // 介绍视频[多张用逗号分隔]
	Picurls        string  `json:"picurls"  xorm:"'PICURLS'"`               // 介绍图片[多张用逗号分隔]
	Descprovinceid int64   `json:"descprovinceid"  xorm:"'DESCPROVINCEID'"` // 目的地(省)ID
	Desccityid     int64   `json:"desccityid"  xorm:"'DESCCITYID'"`         // 目的地(市)ID
	Goodsdesc      string  `json:"goodsdesc"  xorm:"'GOODSDESC'"`           // 商品详情
	Goodsprice     float64 `json:"goodsprice"  xorm:"'GOODSPRICE'"`         // 商品价格

	Currency     string `json:"currency" xorm:"'CURRENCY'"`         // 货币
	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号

	Vendorname  string `json:"vendorname"  xorm:"'VENDORNAME'"`   // 供应商名称
	Vendorphone string `json:"vendorphone"  xorm:"'VENDORPHONE'"` // 供应商客服电话
	Vendorattr  string `json:"vendorattr"  xorm:"'VENDORATTR'"`   // 供应商附件(多张，逗号分隔)

	Trademode int32 `json:"trademode"  xorm:"'TRADEMODE'" binding:"required"` // 交易模式 - 10:做市 13:竞价 15:通道交易 16:挂牌点选 17:仓单贸易 18:期权 19:竞拍-降价式 20:竞拍-竞价式 21:竞拍-大宗式 22:受托竞价

	Last      float64 `json:"last" xorm:"-"`         // 现价
	Limitup   float64 `json:"limitup" xorm:"-"`      // 涨停价
	Limitdown float64 `json:"limitdown" xorm:"-"`    // 跌停价
	StepValue float64 `json:"stepvalue" xorm:"-"`    // 价格最小变动单位
	LotSize   int     `json:"lotsize" xorm:"-"`      // 手数最小变动单位
	Buymaxqty int     `json:"buymaxqty"  xorm:"'-'"` // 购买上限 [71] - 0为不限
}

// GetHsbyListingGoodsDetail 获取二级市场（挂牌点选）商品信息详情
// 参数 goodsID int 目标商品ID
// 返回 *HsbyListingGoodsDetail 二级市场（挂牌点选）商品信息详情，查询无结果返回nil
// 返回 error error
func GetHsbyListingGoodsDetail(goodsID, accountID int) (*HsbyListingGoodsDetail, error) {
	engine := db.GetEngine()

	details := make([]HsbyListingGoodsDetail, 0)
	// 获取挂牌商品信息，以及扩展表信息
	// FIXME: - 这里使用Get方法，会造成SQL语句的嵌套出错，后期再研究
	session := engine.Table("GOODS").
		Select(`GOODS.GOODSID, GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.MARKETID, GOODS.QUOTEMINUNIT, GOODS.AGREEUNIT, 
				HSBY_GOODSEX.HOTINDEX, HSBY_GOODSEX.VIDEOURLS, HSBY_GOODSEX.PICURLS, HSBY_GOODSEX.DESCPROVINCEID, HSBY_GOODSEX.Desccityid, HSBY_GOODSEX.Goodsdesc, HSBY_GOODSEX.GOODSPRICE, 
				ENUMDICITEM.ENUMDICNAME CURRENCY, ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HSBY_SUPPLIERINFO.VENDORNAME, HSBY_SUPPLIERINFO.VENDORPHONE, HSBY_SUPPLIERINFO.VENDORATTR, 
				MARKET.TRADEMODE`).
		Join("LEFT", "HSBY_GOODSEX", "HSBY_GOODSEX.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "ENUMDICITEM.ENUMITEMNAME = GOODS.CURRENCYID and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "HSBY_SUPPLIERINFO", "HSBY_SUPPLIERINFO.VENDORID = HSBY_GOODSEX.VENDORID").
		Join("LEFT", "MARKET", "MARKET.MARKETID = GOODS.MARKETID").
		Where("GOODS.GOODSID = ?", goodsID)
	if err := session.Find(&details); err != nil {
		return nil, err
	}
	// 无目标商品
	if len(details) == 0 {
		return nil, nil
	}
	hsbyListingGoodsDetail := details[0]

	// 获取商品现价和涨跌停价
	quoteDays, err := GetQuoteDays(hsbyListingGoodsDetail.Goodscode)
	if err != nil {
		return nil, err
	}
	if len(quoteDays) > 0 {
		if quoteDays[0].Last != 0 {
			hsbyListingGoodsDetail.Last = utils.IntToFloat64(int(quoteDays[0].Last), int(hsbyListingGoodsDetail.Decimalplace))
		}
		// 没有现价则尝试用昨结
		if hsbyListingGoodsDetail.Last == 0 && quoteDays[0].Presettle != 0 {
			hsbyListingGoodsDetail.Last = utils.IntToFloat64(int(quoteDays[0].Presettle), int(hsbyListingGoodsDetail.Decimalplace))
		}
		if quoteDays[0].Limitup != 0 {
			hsbyListingGoodsDetail.Limitup = utils.IntToFloat64(int(quoteDays[0].Limitup), int(hsbyListingGoodsDetail.Decimalplace))
		}
		if quoteDays[0].Limitdown != 0 {
			hsbyListingGoodsDetail.Limitdown = utils.IntToFloat64(int(quoteDays[0].Limitdown), int(hsbyListingGoodsDetail.Decimalplace))
		}
	}

	// 计算价格最小变动单位
	stepValue := float64(hsbyListingGoodsDetail.Quoteminunit) * math.Pow(0.1, float64(hsbyListingGoodsDetail.Decimalplace))
	hsbyListingGoodsDetail.StepValue, _ = strconv.ParseFloat(utils.FormatFloat(stepValue, int(hsbyListingGoodsDetail.Decimalplace)), 64)

	// 计算手数最小变动单位，改在上层进行设置，这里暂时设置成1
	hsbyListingGoodsDetail.LotSize = 1

	return &hsbyListingGoodsDetail, nil
}

// HsbyGoodsOrderDetail 二级市场挂牌商品当前可摘委托单信息
type HsbyGoodsOrderDetail struct {
	Orderid    string    `json:"orderid"  xorm:"'ORDERID'" binding:"required"`     // 委托单号(100+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	Buyorsell  int32     `json:"buyorsell"  xorm:"'BUYORSELL'" binding:"required"` // 买卖 - 0:买 1:卖
	Ordertime  time.Time `json:"ordertime"  xorm:"'ORDERTIME'" binding:"required"` // 委托时间
	Orderprice float64   `json:"orderprice"  xorm:"'ORDERPRICE'"`                  // 委托价格
	Enableqty  int64     `json:"enableqty" xorm:"ENABLEQTY"`                       // 可用数量

	Customername string `json:"customername"  xorm:"'CUSTOMERNAME'"` // 客户名称(企业名称)，已脱敏

	Currencysign string `json:"currencysign" xorm:"-"` // 货币符号
	Goodunit     string `json:"goodunit"  xorm:"-"`    // 报价单位
}

// GetHsbyGoodsOrderDetails 获取二级市场（挂牌点选）商品对应的挂牌委托单信息
// 输入 goodsID int 商品ID
// 输入 buyOrSell int 挂牌委托单方向（对手单方向），0：买 1：卖
// 输入 price float64 参考价格。买方向委托单则价格小于等于（站在摘牌人的角度）；卖方向委托单则价格大于等于
// 输出 []HsbyGoodsOrderDetail 商品对应的挂牌委托单信息
// 输出 error error
func GetHsbyGoodsOrderDetails(goodsID, buyOrSell int, price float64, accountIDs string) ([]HsbyGoodsOrderDetail, error) {
	engine := db.GetEngine()

	// 获取与目标商品相关的挂牌委托单信息（ListingSelectType = 1 or 3; OrderStatus =3 or 7）
	hsbyGoodsOrderDetails := make([]HsbyGoodsOrderDetail, 0)
	session := engine.Table("TRADE_ORDERDETAIL").
		Select(`to_char(TRADE_ORDERDETAIL.ORDERID) ORDERID, TRADE_ORDERDETAIL.BUYORSELL, TRADE_ORDERDETAIL.ORDERTIME, TRADE_ORDERDETAIL.ORDERPRICE, (TRADE_ORDERDETAIL.ORDERQTY - TRADE_ORDERDETAIL.TRADEQTY - TRADE_ORDERDETAIL.CANCELQTY) ENABLEQTY,
				substr(USERINFO.CUSTOMERNAME,0,1)||'****' as CUSTOMERNAME`).
		Join("LEFT", "TAACCOUNT", "TAACCOUNT.ACCOUNTID = TRADE_ORDERDETAIL.ACCOUNTID").
		Join("LEFT", "USERINFO", "USERINFO.USERID = TAACCOUNT.RELATEDUSERID").
		Where("(TRADE_ORDERDETAIL.LISTINGSELECTTYPE = 1 or TRADE_ORDERDETAIL.LISTINGSELECTTYPE = 3) and (TRADE_ORDERDETAIL.ORDERSTATUS = 3 or TRADE_ORDERDETAIL.ORDERSTATUS = 7)").
		And("TRADE_ORDERDETAIL.GOODSID = ?", goodsID).
		And("TRADE_ORDERDETAIL.BUYORSELL = ?", buyOrSell)
	if len(accountIDs) > 0 {
		session = session.And(fmt.Sprintf("TRADE_ORDERDETAIL.ACCOUNTID not in (%s)", accountIDs))
	}
	if price > 0 {
		if buyOrSell == 0 {
			// 对手单买方向委托单则价格大于等于（站在摘牌人的角度，摘牌方面是卖，我的闲置下单）
			session = session.And("TRADE_ORDERDETAIL.ORDERPRICE >= ?", price)
		} else {
			// 对手单卖方向委托单则价格小于等于（站在摘牌人的角度，摘牌方面是买，热门商品下单）
			session = session.And("TRADE_ORDERDETAIL.ORDERPRICE <= ?", price)
		}
	}
	if err := session.Find(&hsbyGoodsOrderDetails); err != nil {
		return nil, err
	}

	// 获取商品货币符号和报价单位
	goods, err := GetGoods(goodsID)
	if err != nil {
		return nil, err
	}
	currencyEnums, err := GetEnumDicItem("currency", int(goods.Currencyid))
	if err != nil {
		return nil, err
	}
	currencysign := ""
	if len(currencyEnums) > 0 {
		currencysign = currencyEnums[0].Param2
	}
	goodsUnitEnums, err := GetEnumDicItem("goodsunit", int(goods.Goodunitid))
	if err != nil {
		return nil, err
	}
	goodsUnit := ""
	if len(goodsUnitEnums) > 0 {
		goodsUnit = goodsUnitEnums[0].Enumdicname
	}

	for i := range hsbyGoodsOrderDetails {
		orderDetail := &hsbyGoodsOrderDetails[i]

		// 设置货币符号和报价单位
		orderDetail.Currencysign = currencysign
		orderDetail.Goodunit = goodsUnit
	}

	return hsbyGoodsOrderDetails, nil
}

// HybsMyBuyOrderDetail 我的订单（一二级市场的买方向委托单）
type HybsMyBuyOrderDetail struct {
	Orderid           string    `json:"orderid"  xorm:"'ORDERID'" binding:"required"`     // 委托单号(100+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	Marketid          int32     `json:"marketid"  xorm:"'MARKETID'" binding:"required"`   // 市场ID
	Goodsid           int32     `json:"goodsid"  xorm:"'GOODSID'" binding:"required"`     // 商品ID
	Accountid         int64     `json:"accountid"  xorm:"'ACCOUNTID'" binding:"required"` // 账户ID[报价币种]
	Buyorsell         int32     `json:"buyorsell"  xorm:"'BUYORSELL'" binding:"required"` // 买卖 - 0:买 1:卖
	Orderprice        float64   `json:"orderprice"  xorm:"'ORDERPRICE'"`                  // 委托价格
	Orderqty          int64     `json:"orderqty"  xorm:"'ORDERQTY'" binding:"required"`   // 委托数量
	Tradeqty          int64     `json:"tradeqty"  xorm:"'TRADEQTY'"`                      // 成交数量
	Cancelqty         int64     `json:"cancelqty"  xorm:"'CANCELQTY'"`                    // 撤单数量
	Ordertime         time.Time `json:"ordertime"  xorm:"'ORDERTIME'" binding:"required"` // 委托时间
	Listingselecttype int32     `json:"listingselecttype"  xorm:"'LISTINGSELECTTYPE'"`    // 挂牌点选类型 - 1:挂牌 2:摘牌 3:先摘后挂
	Orderstatus       int32     `json:"orderstatus"  xorm:"'ORDERSTATUS'"`                // 委托状态 - 1： 委托请求 2：待冻结 3：委托成功 4： 委托失败 5：配对成功 6： 已撤销 7：部分成交 8：已成交 9：部成部撤 10：成交失败 11：已拒绝 12:经过摘牌(先摘后挂专用-先摘后挂已摘过) 13:冻结成功(通道交易专用) 14:通道已撤 15:通道部成部撤 16:成交失败违约(荷兰式竞拍专用)

	Goodscode    string  `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string  `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64   `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Agreeunit    float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位

	Picurls1 string `json:"picurls1"  xorm:"'PICURLS1'"` // 预售商品介绍图片[多张用逗号分隔]
	Picurls2 string `json:"picurls2"  xorm:"'PICURLS2'"` // 挂牌商品介绍图片[多张用逗号分隔]

	Trademode uint32 `json:"trademode"  xorm:"'TRADEMODE'" binding:"required"` // 交易模式 - 10:做市 13:竞价 15:通道交易 16:挂牌点选 17:仓单贸易 18:期权 19:竞拍-降价式 20:竞拍-竞价式 21:竞拍-大宗式 22:受托竞价

	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号

	Vendorname1 string `json:"vendorname1"  xorm:"'VENDORNAME1'"` // 预售商品供应商名称
	Vendorname2 string `json:"vendorname2"  xorm:"'VENDORNAME2'"` // 挂牌商品供应商名称

	MyBuyStatus int     `json:"mybuystatus" xorm:"-"` // "我的订单"显示状态- 1：抢购中 2：求购中 3：已完成 4：已撤消 5：委托失败
	Orderamount float64 `json:"orderamount" xorm:"-"` // 委托金额
}

// GetHsbyBuyMyOrderDetails 获取“我的订单”数据（包括一二级市场）
// 输入 accountIDs string 资金账户列表
// 输入 myBuyStatus int "我的订单"状态, 1：抢购中 2：求购中 3：已完成
// 输出 []HybsMyBuyOrderDetail “我的订单”数据
// 输出 error error
func GetHsbyBuyMyOrderDetails(accountIDs string, myBuyStatus int) ([]HybsMyBuyOrderDetail, error) {
	// 获取市场信息
	markets, err := GetMarkets()
	if err != nil {
		return nil, err
	}

	engine := db.GetEngine()
	// 委托状态
	orderStatus := "0" // 单据状态，为0的时候查询全部
	marketIDs := ""    // 我的订单包括一二级市场的单据
	// FIXME: myBuyStatus 目前终端不传
	switch myBuyStatus {
	case 1: // 抢购中 (一级市场)
		// 获取市场ID
		for _, v := range markets {
			if v.Trademode == 71 { // 预售挂牌
				if len(marketIDs) == 0 {
					marketIDs = strconv.Itoa(int(v.Marketid))
				} else {
					marketIDs += "," + strconv.Itoa(int(v.Marketid))
				}
			}
		}
		orderStatus = "3,7"
	case 2: // 求购中（二级市场）
		// 获取市场ID
		for _, v := range markets {
			if v.Trademode == 16 { // 挂牌点选
				if len(marketIDs) == 0 {
					marketIDs = strconv.Itoa(int(v.Marketid))
				} else {
					marketIDs += "," + strconv.Itoa(int(v.Marketid))
				}
			}
		}
		orderStatus = "3,7"
	case 3: // 已完成
		orderStatus = "8,9"
	}
	// 默认取 TradeMode = 16 or 71 的市场
	if len(marketIDs) == 0 {
		for _, v := range markets {
			if v.Trademode == 16 || v.Trademode == 71 || v.Trademode == 70 {
				if len(marketIDs) == 0 {
					marketIDs = strconv.Itoa(int(v.Marketid))
				} else {
					marketIDs += "," + strconv.Itoa(int(v.Marketid))
				}
			}
		}
	}

	hybsMyBuyOrderDetails := make([]HybsMyBuyOrderDetail, 0)
	// "我的订单"都是买委托
	session := engine.Table("TRADE_ORDERDETAIL").
		Select(`to_char(TRADE_ORDERDETAIL.ORDERID) ORDERID, TRADE_ORDERDETAIL.*, 
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HG1.PICURLS PICURLS1, 
				HG2.PICURLS PICURLS2, 
				MARKET.TRADEMODE, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN,
				HS1.VENDORNAME VENDORNAME1, 
				HS2.VENDORNAME VENDORNAME2`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = TRADE_ORDERDETAIL.GOODSID").
		Join("LEFT", "CPTRADE_PRESALEGOODSEX", "CPTRADE_PRESALEGOODSEX.GOODSID = TRADE_ORDERDETAIL.GOODSID").
		Join("LEFT", "HSBY_GOODSEX HG1", "HG1.GOODSID = CPTRADE_PRESALEGOODSEX.RELATEDGOODSID").
		Join("LEFT", "HSBY_GOODSEX HG2", "HG2.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "GOODS.CURRENCYID = ENUMDICITEM.ENUMITEMNAME and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET", "MARKET.MARKETID = TRADE_ORDERDETAIL.MARKETID").
		Join("LEFT", "HSBY_SUPPLIERINFO HS1", "HS1.VENDORID = HG1.VENDORID").
		Join("LEFT", "HSBY_SUPPLIERINFO HS2", "HS2.VENDORID = HG2.VENDORID").
		Where(fmt.Sprintf("TRADE_ORDERDETAIL.BUYORSELL = 0 and TRADE_ORDERDETAIL.ACCOUNTID in (%s)", accountIDs)).
		And(fmt.Sprintf("TRADE_ORDERDETAIL.MARKETID in (%s)", marketIDs))
	// 是否过滤状态（抢购中、求购中、已完成）
	if orderStatus != "0" {
		session = session.And(fmt.Sprintf("TRADE_ORDERDETAIL.ORDERSTATUS in (%s)", orderStatus))
	}
	if err := session.Find(&hybsMyBuyOrderDetails); err != nil {
		return nil, err
	}

	// 设置“我的订单”显示状态
	for i := range hybsMyBuyOrderDetails {
		detail := &hybsMyBuyOrderDetails[i]

		// 委托金额 = 委托价格 * 委托数量 * 合约单位
		detail.Orderamount = detail.Orderprice * float64(detail.Orderqty) * float64(detail.Agreeunit)

		if detail.Trademode == 71 && (detail.Orderstatus == 3 || detail.Orderstatus == 7) {
			// 抢购中
			detail.MyBuyStatus = 1
		} else if detail.Trademode == 16 && (detail.Orderstatus == 3 || detail.Orderstatus == 7) {
			// 求购中
			detail.MyBuyStatus = 2
		} else if detail.Orderstatus == 8 || detail.Orderstatus == 9 {
			// 已完成
			detail.MyBuyStatus = 3
		} else if detail.Orderstatus == 6 || detail.Orderstatus == 22 {
			// 已撤销
			detail.MyBuyStatus = 4
		} else if detail.Orderstatus == 4 {
			// 委托失败
			detail.MyBuyStatus = 5
		}
	}

	return hybsMyBuyOrderDetails, nil
}

// HsbyMyGoods 我的商品（买方向持仓）
type HsbyMyGoods struct {
	Accountid          int64   `json:"accountid"  xorm:"'ACCOUNTID'" binding:"required"` // 账号Id
	Goodsid            int32   `json:"goodsid"  xorm:"'GOODSID'" binding:"required"`     // 商品Id
	Buycurpositionqty  int64   `json:"buycurpositionqty"  xorm:"'BUYCURPOSITIONQTY'"`    // 买当前持仓总数量
	Buycurholderamount float64 `json:"buycurholderamount"  xorm:"'BUYCURHOLDERAMOUNT'"`  // 买当前持仓总金额[商品币种]
	EnableQty          int64   `json:"enableqty" xorm:"'ENABLEQTY'"`                     // 可用数量

	Goodscode    string  `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string  `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64   `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Agreeunit    float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位
	Goodsstatus  int64   `json:"goodsstatus"  xorm:"'GOODSSTATUS'"`                // 商品状态- 1:待审核 2:未上市 3:上市 4:已注销 5:审核拒绝 6:退市 7:待退市
	Marketid     int64   `json:"marketid"  xorm:"'MARKETID'" binding:"required"`   // 所属市场ID
	Quoteminunit int64   `json:"quoteminunit"  xorm:"'QUOTEMINUNIT'"`              // 行情最小变动单位 [整数，报价小数位一起使用]

	Picurls    string  `json:"picurls"  xorm:"'PICURLS'"`       // 介绍图片[多张用逗号分隔]
	Goodsprice float64 `json:"goodsprice"  xorm:"'GOODSPRICE'"` // 商品价格

	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号

	Trademode int32 `json:"trademode"  xorm:"'TRADEMODE'" binding:"required"` // 交易模式 - 10:做市 13:竞价 15:通道交易 16:挂牌点选 17:仓单贸易 18:期权 19:竞拍-降价式 20:竞拍-竞价式 21:竞拍-大宗式 22:受托竞价

	Buyaverageprice float64 `json:"buyaverageprice" xorm:"-"` // 持仓均价

	Last      float64 `json:"last" xorm:"-"`         // 现价（仅使用于挂牌点选）
	Limitup   float64 `json:"limitup" xorm:"-"`      // 涨停价（仅使用于挂牌点选）
	Limitdown float64 `json:"limitdown" xorm:"-"`    // 跌停价（仅使用于挂牌点选）
	StepValue float64 `json:"stepvalue" xorm:"-"`    // 价格最小变动单位
	LotSize   int     `json:"lotsize" xorm:"-"`      // 手数最小变动单位
	Buymaxqty int     `json:"buymaxqty"  xorm:"'-'"` // 购买上限 [71] - 0为不限
}

// GetHsbyMyGoods 获取“我的商品”信息
// 输入 accountIDs string 资金账户列表，格式 1,2,3
// 输出 []HsbyMyGoods “我的商品”信息
// 输入 error error
func GetHsbyMyGoods(accountIDs string) ([]HsbyMyGoods, error) {
	engine := db.GetEngine()

	hsbyMyGoodses := make([]HsbyMyGoods, 0)
	// 此定制版本，只查询出当前手数（期末）大于0的数据 （TRADEPOSITION.BUYCURPOSITIONQTY > 0）
	if err := engine.Table("TRADEPOSITION TP").
		Select(`TP.*, (TP.BUYCURPOSITIONQTY - TP.BUYFROZENQTY - TP.BUYOTHERFROZENQTY) ENABLEQTY, 
				G.GOODSCODE, G.GOODSNAME, G.DECIMALPLACE, G.AGREEUNIT, G.GOODSSTATUS, G.MARKETID, G.QUOTEMINUNIT, 
				GX.PICURLS, GX.GOODSPRICE,  
				E.PARAM2 CURRENCYSIGN, 
				M.TRADEMODE`).
		Join("LEFT", "GOODS G", "G.GOODSID = TP.GOODSID").
		Join("INNER", "HSBY_GOODSEX GX", "GX.GOODSID = G.GOODSID").
		Join("LEFT", "ENUMDICITEM E", "G.CURRENCYID = E.ENUMITEMNAME and E.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET M", "M.MARKETID = G.MARKETID").
		Where(fmt.Sprintf("G.GOODSSTATUS = 3 and TP.BUYCURPOSITIONQTY > 0 and TP.ACCOUNTID in (%s)", accountIDs)).Find(&hsbyMyGoodses); err != nil {
		return nil, err
	}

	for i := range hsbyMyGoodses {
		myGoods := &hsbyMyGoodses[i]

		// 持仓均价
		averagePrice := myGoods.Buycurholderamount / float64(myGoods.Buycurpositionqty) / myGoods.Agreeunit
		myGoods.Buyaverageprice, _ = strconv.ParseFloat(utils.FormatFloat(averagePrice, int(myGoods.Decimalplace)), 64)

		// 获取商品现价和涨跌停价（挂牌点选）
		if myGoods.Trademode == 16 {
			quoteDays, err := GetQuoteDays(myGoods.Goodscode)
			if err != nil {
				return nil, err
			}
			if len(quoteDays) > 0 {
				if quoteDays[0].Last != 0 {
					myGoods.Last = utils.IntToFloat64(int(quoteDays[0].Last), int(myGoods.Decimalplace))
				}
				// 没有现价则尝试用昨结
				if myGoods.Last == 0 && quoteDays[0].Presettle != 0 {
					myGoods.Last = utils.IntToFloat64(int(quoteDays[0].Presettle), int(myGoods.Decimalplace))
				}
				if quoteDays[0].Limitup != 0 {
					myGoods.Limitup = utils.IntToFloat64(int(quoteDays[0].Limitup), int(myGoods.Decimalplace))
				}
				if quoteDays[0].Limitdown != 0 {
					myGoods.Limitdown = utils.IntToFloat64(int(quoteDays[0].Limitdown), int(myGoods.Decimalplace))
				}
			}
		}

		// 计算价格最小变动单位
		stepValue := float64(myGoods.Quoteminunit) * math.Pow(0.1, float64(myGoods.Decimalplace))
		myGoods.StepValue, _ = strconv.ParseFloat(utils.FormatFloat(stepValue, int(myGoods.Decimalplace)), 64)

		// 获取交易规则
		accountID, err := strconv.Atoi(accountIDs)
		if err != nil {
			return nil, err
		}
		rule, err := GetTodayAccountTradeRule(accountID, int(myGoods.Goodsid))
		if err != nil {
			// 查询失败
			return nil, err
		}
		if rule != nil {
			tradeRuleInfoStruct := &pb.TradeRuleInfoStruct{}
			if err := proto.Unmarshal([]byte(rule.Infocontent), tradeRuleInfoStruct); err != nil {
				// 查询失败
				return nil, err
			}
			// INSERT INTO TRADERULEDESCRIPTION (RULEID, RULENAME, REGEXPRESS, DEFAULTVALUE, REMARK) VALUES (103, '单笔最小交易量', '^[1-9]\d*$', 1, '请输入正整数!');
			for _, v := range tradeRuleInfoStruct.TradeRules {
				if int(*v.RuleID) == 103 {
					myGoods.LotSize = int(*v.ParamValue)
				}
				// 挂牌点选的最大建仓手数与预售的不一样，直接从规则里取
				if int(*v.RuleID) == 104 {
					myGoods.Buymaxqty = int(*v.ParamValue)
				}
			}
		}
	}

	return hsbyMyGoodses, nil
}

// HsbyPreGoods 新品上市商品（一级市场产能预售）
type HsbyPreGoods struct {
	Goodsid       int64     `json:"goodsid"  xorm:"'GOODSID'" binding:"required"`     // 商品ID(自增ID SEQ_GOODS)
	Goodscode     string    `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname     string    `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace  int64     `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Marketid      int64     `json:"marketid"  xorm:"'MARKETID'" binding:"required"`   // 所属市场ID
	Goodsstatus   int64     `json:"goodsstatus"  xorm:"'GOODSSTATUS'"`                // 商品状态- 2:未上市 3:上市
	Quoteminunit  int64     `json:"quoteminunit"  xorm:"'QUOTEMINUNIT'"`              // 行情最小变动单位 [整数，报价小数位一起使用]
	Agreeunit     float64   `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位
	Listingdate   time.Time `json:"listingdate"  xorm:"'LISTINGDATE'"`                // 交易开始日期
	Lasttradedate time.Time `json:"lasttradedate"  xorm:"'LASTTRADEDATE'"`            // 最后交易日期(状态：待退市)

	Relatedgoodsid int64   `json:"relatedgoodsid"  xorm:"'RELATEDGOODSID'"` // 关联交易合约ID
	Presaleqty     int64   `json:"presaleqty"  xorm:"'PRESALEQTY'"`         // 预售数量
	Refprice       float64 `json:"refprice"  xorm:"'REFPRICE'"`             // 参考价格[一口价]
	Presaledqty    int64   `json:"presaledqty"  xorm:"'PRESALEDQTY'"`       // 已预售量(预售结束时更新)
	EnableQty      int64   `json:"enableqty" xorm:"ENABLEQTY"`              // 剩余数量

	Currency     string `json:"currency" xorm:"'CURRENCY'"`         // 货币
	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号

	Videourls string `json:"videourls"  xorm:"'VIDEOURLS'"` // 介绍视频[多张用逗号分隔]
	Picurls   string `json:"picurls"  xorm:"'PICURLS'"`     // 介绍图片[多张用逗号分隔]

	Trademode int32 `json:"trademode"  xorm:"'TRADEMODE'" binding:"required"` // 交易模式 - 10:做市 13:竞价 15:通道交易 16:挂牌点选 17:仓单贸易 18:期权 19:竞拍-降价式 20:竞拍-竞价式 21:竞拍-大宗式 22:受托竞价
}

// GetHsbyPreGoodses 获取“新品上市”商品列表（一级市场产能预售）
// 输入 marketIDs string 市场ID列表，格式 1,2,3
// 输入 descProvinceID int 省ID
// 输入 descCityID int 市ID
// 输出 []HsbyPreGoods “新品上市”商品列表
// 输出 error error
func GetHsbyPreGoodses(marketIDs string, descProvinceID, descCityID int) ([]HsbyPreGoods, error) {
	engine := db.GetEngine()

	// 注意：一级产能预售市场使用的商品实际上是和二级市场有关系的，所以要使用 CPTRADE_PRESALEGOODSEX.RELATEDGOODSID 进行关联
	// 注意：CPTRADE_PRESALEGOODSEX 表的开始与结束时间是给大宗用的
	preGoodses := make([]HsbyPreGoods, 0)
	session := engine.Table("GOODS").
		Select(`GOODS.*, 
				CPTRADE_PRESALEGOODSEX.RELATEDGOODSID, CPTRADE_PRESALEGOODSEX.PRESALEQTY, CPTRADE_PRESALEGOODSEX.REFPRICE, 
				CPTRADE_PRESALEGOODSEX.PRESALEDQTY, (CPTRADE_PRESALEGOODSEX.PRESALEQTY - CPTRADE_PRESALEGOODSEX.PRESALEDQTY) ENABLEQTY, 
				ENUMDICITEM.ENUMDICNAME CURRENCY, ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HSBY_GOODSEX.VIDEOURLS, HSBY_GOODSEX.PICURLS, 
				MARKET.TRADEMODE`).
		Join("INNER", "CPTRADE_PRESALEGOODSEX", "CPTRADE_PRESALEGOODSEX.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "ENUMDICITEM.ENUMITEMNAME = GOODS.CURRENCYID and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "HSBY_GOODSEX", "HSBY_GOODSEX.GOODSID = CPTRADE_PRESALEGOODSEX.RELATEDGOODSID").
		Join("LEFT", "MARKET", "MARKET.MARKETID = GOODS.MARKETID").
		Where(fmt.Sprintf("GOODS.GOODSSTATUS in (2,3) and GOODS.MARKETID in (%s)", marketIDs)) // 一级市场获取 2:未上市 3:上市 状态的商品
	if descProvinceID > 0 {
		session = session.And("HSBY_GOODSEX.DESCPROVINCEID = ?", descProvinceID)
	}
	if descCityID > 0 {
		session = session.And("HSBY_GOODSEX.DESCCITYID = ?", descCityID)
	}
	if err := session.Find(&preGoodses); err != nil {
		return nil, err
	}

	// for i := range preGoodses {
	// 	preGoods := &preGoodses[i]

	// 	// FIXME: - 这里应该使用 Duck Typing，后期再处理
	// 	// 计算最小变动单位
	// 	lotSize := float64(preGoods.Quoteminunit) * math.Pow(0.1, float64(preGoods.Decimalplace))
	// 	preGoods.LotSize, _ = strconv.ParseFloat(utils.FormatFloat(lotSize, int(preGoods.Decimalplace)), 64)
	// }

	return preGoodses, nil
}

// HsbyPreGoodsDetail 一级市场（产能预售）商品信息详情
type HsbyPreGoodsDetail struct {
	Goodsid       int64     `json:"goodsid"  xorm:"'GOODSID'" binding:"required"`     // 商品ID(自增ID SEQ_GOODS)
	Goodscode     string    `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname     string    `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace  int64     `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Marketid      int64     `json:"marketid"  xorm:"'MARKETID'" binding:"required"`   // 所属市场ID
	Goodsstatus   int64     `json:"goodsstatus"  xorm:"'GOODSSTATUS'"`                // 商品状态- 2:未上市 3:上市
	Quoteminunit  int64     `json:"quoteminunit"  xorm:"'QUOTEMINUNIT'"`              // 行情最小变动单位 [整数，报价小数位一起使用]
	Agreeunit     float64   `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位
	Listingdate   time.Time `json:"listingdate"  xorm:"'LISTINGDATE'"`                // 交易开始日期
	Lasttradedate time.Time `json:"lasttradedate"  xorm:"'LASTTRADEDATE'"`            // 最后交易日期(状态：待退市)

	Relatedgoodsid int64   `json:"relatedgoodsid"  xorm:"'RELATEDGOODSID'"` // 关联交易合约ID
	Presaleqty     int64   `json:"presaleqty"  xorm:"'PRESALEQTY'"`         // 预售数量
	Refprice       float64 `json:"refprice"  xorm:"'REFPRICE'"`             // 参考价格[一口价]
	Presaledqty    int64   `json:"presaledqty"  xorm:"'PRESALEDQTY'"`       // 已预售量(预售结束时更新)
	EnableQty      int64   `json:"enableqty" xorm:"ENABLEQTY"`              // 剩余数量
	Buymaxqty      int     `json:"buymaxqty"  xorm:"'BUYMAXQTY'"`           // 购买上限 [71] - 0为不限

	Videourls      string `json:"videourls"  xorm:"'VIDEOURLS'"`           // 介绍视频[多张用逗号分隔]
	Picurls        string `json:"picurls"  xorm:"'PICURLS'"`               // 介绍图片[多张用逗号分隔]
	Descprovinceid int64  `json:"descprovinceid"  xorm:"'DESCPROVINCEID'"` // 目的地(省)ID
	Desccityid     int64  `json:"desccityid"  xorm:"'DESCCITYID'"`         // 目的地(市)ID
	Goodsdesc      string `json:"goodsdesc"  xorm:"'GOODSDESC'"`           // 商品详情

	Currency     string `json:"currency" xorm:"'CURRENCY'"`         // 货币
	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号
	Goodunit     string `json:"goodunit"  xorm:"GOODUNIT"`          // 报价单位

	Vendorname  string `json:"vendorname"  xorm:"'VENDORNAME'"`   // 供应商名称
	Vendorphone string `json:"vendorphone"  xorm:"'VENDORPHONE'"` // 供应商客服电话
	Vendorattr  string `json:"vendorattr"  xorm:"'VENDORATTR'"`   // 供应商附件(多张，逗号分隔)

	Trademode int32 `json:"trademode"  xorm:"'TRADEMODE'" binding:"required"` // 交易模式 - 10:做市 13:竞价 15:通道交易 16:挂牌点选 17:仓单贸易 18:期权 19:竞拍-降价式 20:竞拍-竞价式 21:竞拍-大宗式 22:受托竞价

	Customername string `json:"customername" xorm:"'CUSTOMERNAME'"` // 发行单位

	StepValue float64 `json:"stepvalue" xorm:"-"` // 价格最小变动单位
	LotSize   int     `json:"lotsize" xorm:"-"`   // 手数最小变动单位
}

// GetHsbyPreGoodsDetail 获取一级市场（产能预售）商品信息详情
// 参数 goodsID int 目标商品ID
// 返回 *HsbyListingGoodsDetail 二级市场（挂牌点选）商品信息详情，查询无结果返回nil
// 返回 error error
func GetHsbyPreGoodsDetail(goodsID, accountID int) (*HsbyPreGoodsDetail, error) {
	engine := db.GetEngine()

	details := make([]HsbyPreGoodsDetail, 0)
	// 获取挂牌商品信息，以及扩展表信息
	// FIXME: - 这里使用Get方法，会造成SQL语句的嵌套出错，后期再研究
	session := engine.Table("GOODS").
		Select(`GOODS.*, 
				CPTRADE_PRESALEGOODSEX.RELATEDGOODSID, CPTRADE_PRESALEGOODSEX.PRESALEQTY, CPTRADE_PRESALEGOODSEX.REFPRICE, 
				CPTRADE_PRESALEGOODSEX.PRESALEDQTY, (CPTRADE_PRESALEGOODSEX.PRESALEQTY - CPTRADE_PRESALEGOODSEX.PRESALEDQTY) ENABLEQTY, CPTRADE_PRESALEGOODSEX.BUYMAXQTY, 
				HSBY_GOODSEX.VIDEOURLS, HSBY_GOODSEX.PICURLS, HSBY_GOODSEX.DESCPROVINCEID, HSBY_GOODSEX.Desccityid, HSBY_GOODSEX.Goodsdesc,
				ENUMDICITEM.ENUMDICNAME CURRENCY, ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				E1.ENUMDICNAME GOODUNIT, 
				HSBY_SUPPLIERINFO.VENDORNAME, HSBY_SUPPLIERINFO.VENDORPHONE, HSBY_SUPPLIERINFO.VENDORATTR, 
				MARKET.TRADEMODE, 
				USERINFO.CUSTOMERNAME`).
		Join("INNER", "CPTRADE_PRESALEGOODSEX", "CPTRADE_PRESALEGOODSEX.GOODSID = GOODS.GOODSID").
		Join("LEFT", "HSBY_GOODSEX", "HSBY_GOODSEX.GOODSID = CPTRADE_PRESALEGOODSEX.RELATEDGOODSID").
		Join("LEFT", "ENUMDICITEM", "ENUMDICITEM.ENUMITEMNAME = GOODS.CURRENCYID and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "ENUMDICITEM E1", "E1.ENUMITEMNAME = GOODS.GOODUNITID and E1.ENUMDICCODE = 'goodsunit'").
		Join("LEFT", "HSBY_SUPPLIERINFO", "HSBY_SUPPLIERINFO.VENDORID = HSBY_GOODSEX.VENDORID").
		Join("LEFT", "MARKET", "MARKET.MARKETID = GOODS.MARKETID").
		Join("LEFT", "USERINFO", "USERINFO.USERID = CPTRADE_PRESALEGOODSEX.USERID").
		Where("GOODS.GOODSID = ?", goodsID)
	if err := session.Find(&details); err != nil {
		return nil, err
	}
	// 无目标商品
	if len(details) == 0 {
		return nil, nil
	}
	preGoodsDetail := details[0]

	// FIXME: - 这里应该使用 Duck Typing，后期再处理
	// 计算价格最小变动单位
	stepValue := float64(preGoodsDetail.Quoteminunit) * math.Pow(0.1, float64(preGoodsDetail.Decimalplace))
	preGoodsDetail.StepValue, _ = strconv.ParseFloat(utils.FormatFloat(stepValue, int(preGoodsDetail.Decimalplace)), 64)

	// 计算手数最小变动单位，一级市场固定为1
	preGoodsDetail.LotSize = 1

	// 获取购买上限
	if accountID != 0 {
		buyMaxQty, err := GetCPTradeBuyLimit(goodsID, accountID)
		if err != nil {
			return nil, err
		}
		preGoodsDetail.Buymaxqty = buyMaxQty
	}

	return &preGoodsDetail, nil
}

// HsbySellMyDetail "我的闲置"单据信息（发布中 - 二级市场卖挂，3：委托成功、7：部分成交; 已完成 - 二级市场成交单，包括历史数据）
type HsbySellMyDetail struct {
	Orderid   string    `json:"orderid"  xorm:"'ORDERID'" binding:"required"`     // 单号（发布中 - 委托单号；已完成 - 成交单号）
	Marketid  int32     `json:"marketid"  xorm:"'MARKETID'" binding:"required"`   // 市场ID
	Goodsid   int32     `json:"goodsid"  xorm:"'GOODSID'" binding:"required"`     // 商品ID
	Accountid int64     `json:"accountid"  xorm:"'ACCOUNTID'" binding:"required"` // 账户ID[报价币种]
	Buyorsell int32     `json:"buyorsell"  xorm:"'BUYORSELL'" binding:"required"` // 买卖 - 0:买 1:卖
	Price     float64   `json:"price"  xorm:"'PRICE'"`                            // 价格
	Time      time.Time `json:"time"  xorm:"'TIME'" binding:"required"`           // 时间
	Qty       int64     `json:"qty"  xorm:"'QTY'"`                                // 数量

	Goodscode    string  `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string  `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64   `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Agreeunit    float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位

	Picurls string `json:"picurls"  xorm:"'PICURLS'"` // 介绍图片[多张用逗号分隔]

	Trademode uint32 `json:"trademode"  xorm:"'TRADEMODE'" binding:"required"` // 交易模式 - 10:做市 13:竞价 15:通道交易 16:挂牌点选 17:仓单贸易 18:期权 19:竞拍-降价式 20:竞拍-竞价式 21:竞拍-大宗式 22:受托竞价

	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号

	Vendorname string `json:"vendorname"  xorm:"'VENDORNAME'"` // 供应商名称

	OrderType int32 `json:"ordertype" xorm:"'ORDERTYPE'"` // 单据类型：0 - 发布中, 1 - 已完成
}

// GetHsbySellMyOrderDetails 获取"我的闲置 - 发布中"单据信息
// 输入 accountIDs string 资金账户列表
// 输出 []HsbySellMyDetail "我的闲置 - 发布中"单据信息
// 输出 error error
func GetHsbySellMyOrderDetails(accountIDs string) ([]HsbySellMyDetail, error) {
	// 获取市场信息
	markets, err := GetMarkets()
	if err != nil {
		return nil, err
	}

	engine := db.GetEngine()
	marketIDs := "" // 我的闲置-发布中： 二级市场卖挂牌、三级商城
	for _, v := range markets {
		if v.Trademode == 16 || v.Trademode == 70 {
			if len(marketIDs) == 0 {
				marketIDs = strconv.Itoa(int(v.Marketid))
			} else {
				marketIDs += "," + strconv.Itoa(int(v.Marketid))
			}
		}
	}

	orderDetails := make([]HsbySellMyDetail, 0)
	// “我的闲置 - 发布中”都是卖挂委托
	session := engine.Table("TRADE_ORDERDETAIL").
		Select(`to_char(TRADE_ORDERDETAIL.ORDERID) ORDERID, 
				TRADE_ORDERDETAIL.MARKETID, TRADE_ORDERDETAIL.GOODSID, TRADE_ORDERDETAIL.ACCOUNTID, TRADE_ORDERDETAIL.BUYORSELL,
				TRADE_ORDERDETAIL.ORDERPRICE PRICE, TRADE_ORDERDETAIL.ORDERTIME TIME, 
				(TRADE_ORDERDETAIL.ORDERQTY - TRADE_ORDERDETAIL.TRADEQTY - TRADE_ORDERDETAIL.CANCELQTY) QTY,
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HSBY_GOODSEX.PICURLS, 
				MARKET.TRADEMODE, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HSBY_SUPPLIERINFO.VENDORNAME, 
				0 ORDERTYPE`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = TRADE_ORDERDETAIL.GOODSID").
		Join("LEFT", "HSBY_GOODSEX", "HSBY_GOODSEX.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "GOODS.CURRENCYID = ENUMDICITEM.ENUMITEMNAME and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET", "MARKET.MARKETID = TRADE_ORDERDETAIL.MARKETID").
		Join("LEFT", "HSBY_SUPPLIERINFO", "HSBY_SUPPLIERINFO.VENDORID = HSBY_GOODSEX.VENDORID").
		Where(fmt.Sprintf(`TRADE_ORDERDETAIL.BUYORSELL = 1 and TRADE_ORDERDETAIL.LISTINGSELECTTYPE = 1 and (TRADE_ORDERDETAIL.ORDERSTATUS = 3 or TRADE_ORDERDETAIL.ORDERSTATUS = 7) 
						   and TRADE_ORDERDETAIL.ACCOUNTID in (%s)`, accountIDs)).
		And(fmt.Sprintf("TRADE_ORDERDETAIL.MARKETID in (%s)", marketIDs))
	if err := session.Find(&orderDetails); err != nil {
		return nil, err
	}

	return orderDetails, nil
}

// GetHsbySellMyTradeDetails 获取"我的闲置 - 已完成"单据信息
// 输入 accountIDs string 资金账户列表
// 输出 []HsbySellMyDetail "我的闲置 - 已完成"单据信息
// 输出 error error
func GetHsbySellMyTradeDetails(accountIDs string) ([]HsbySellMyDetail, error) {
	// 获取市场信息
	markets, err := GetMarkets()
	if err != nil {
		return nil, err
	}

	engine := db.GetEngine()
	marketIDs := "" // 我的闲置-发布中： 二级市场卖方向成交单（包括历史成交单）
	// 默认取 TradeMode = 16
	for _, v := range markets {
		if v.Trademode == 16 {
			if len(marketIDs) == 0 {
				marketIDs = strconv.Itoa(int(v.Marketid))
			} else {
				marketIDs += "," + strconv.Itoa(int(v.Marketid))
			}
		}
	}

	orders := make([]HsbySellMyDetail, 0)

	// 当前成交单
	curOrders := make([]HsbySellMyDetail, 0)
	if err := engine.Table("TRADE_TRADEDETAIL").
		Select(`to_char(TRADE_TRADEDETAIL.TRADEID) ORDERID, 
				TRADE_TRADEDETAIL.MARKETID, TRADE_TRADEDETAIL.GOODSID, TRADE_TRADEDETAIL.ACCOUNTID, TRADE_TRADEDETAIL.BUYORSELL,
				TRADE_TRADEDETAIL.TRADEPRICE PRICE, TRADE_TRADEDETAIL.TRADEQTY QTY, TRADE_TRADEDETAIL.TRADETIME TIME, TRADE_TRADEDETAIL.TRADEAMOUNT AMOUNT, 
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HSBY_GOODSEX.PICURLS, 
				MARKET.TRADEMODE, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HSBY_SUPPLIERINFO.VENDORNAME, 
				1 ORDERTYPE`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = TRADE_TRADEDETAIL.GOODSID").
		Join("LEFT", "HSBY_GOODSEX", "HSBY_GOODSEX.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "GOODS.CURRENCYID = ENUMDICITEM.ENUMITEMNAME and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET", "MARKET.MARKETID = TRADE_TRADEDETAIL.MARKETID").
		Join("LEFT", "HSBY_SUPPLIERINFO", "HSBY_SUPPLIERINFO.VENDORID = HSBY_GOODSEX.VENDORID").
		Where(fmt.Sprintf(`TRADE_TRADEDETAIL.BUYORSELL = 1 and TRADE_TRADEDETAIL.TRADETYPE in (1,24) 
						   and TRADE_TRADEDETAIL.ACCOUNTID in (%s)`, accountIDs)).
		And(fmt.Sprintf("TRADE_TRADEDETAIL.MARKETID in (%s)", marketIDs)).Find(&curOrders); err != nil {
		return nil, err
	}
	if len(curOrders) > 0 {
		orders = append(orders, curOrders...)
	}

	// 历史成交单
	hisOrders := make([]HsbySellMyDetail, 0)
	if err := engine.Table("HIS_TRADE_TRADEDETAIL").
		Select(`to_char(HIS_TRADE_TRADEDETAIL.TRADEID) ORDERID, 
				HIS_TRADE_TRADEDETAIL.MARKETID, HIS_TRADE_TRADEDETAIL.GOODSID, HIS_TRADE_TRADEDETAIL.ACCOUNTID, HIS_TRADE_TRADEDETAIL.BUYORSELL,
				HIS_TRADE_TRADEDETAIL.TRADEPRICE PRICE, HIS_TRADE_TRADEDETAIL.TRADEQTY QTY, HIS_TRADE_TRADEDETAIL.TRADETIME TIME, HIS_TRADE_TRADEDETAIL.TRADEAMOUNT AMOUNT, 
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HSBY_GOODSEX.PICURLS, 
				MARKET.TRADEMODE, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HSBY_SUPPLIERINFO.VENDORNAME, 
				1 ORDERTYPE`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = HIS_TRADE_TRADEDETAIL.GOODSID").
		Join("LEFT", "HSBY_GOODSEX", "HSBY_GOODSEX.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "GOODS.CURRENCYID = ENUMDICITEM.ENUMITEMNAME and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET", "MARKET.MARKETID = HIS_TRADE_TRADEDETAIL.MARKETID").
		Join("LEFT", "HSBY_SUPPLIERINFO", "HSBY_SUPPLIERINFO.VENDORID = HSBY_GOODSEX.VENDORID").
		Where(fmt.Sprintf(`HIS_TRADE_TRADEDETAIL.BUYORSELL = 1 and HIS_TRADE_TRADEDETAIL.TRADETYPE in (1,24) and HIS_TRADE_TRADEDETAIL.ISVALIDDATA = 1 
						   and HIS_TRADE_TRADEDETAIL.ACCOUNTID in (%s)`, accountIDs)).
		And(fmt.Sprintf("HIS_TRADE_TRADEDETAIL.MARKETID in (%s)", marketIDs)).Find(&hisOrders); err != nil {
		return nil, err
	}
	if len(hisOrders) > 0 {
		orders = append(orders, hisOrders...)
	}

	return orders, nil
}

// HsbyMyPackage 我的包裹信息
type HsbyMyPackage struct {
	Takeorderid     string    `json:"takeorderid"  xorm:"'TAKEORDERID'" binding:"required"` // 提货单号(905+Unix秒时间戳(10位)+xxxxxx)
	Accountid       int64     `json:"accountid"  xorm:"'ACCOUNTID'"`                        // 账户ID
	Goodsid         int64     `json:"goodsid"  xorm:"'GOODSID'"`                            // 商品ID
	Userid          int64     `json:"userid"  xorm:"'USERID'"`                              // 用户ID
	Qty             float64   `json:"qty"  xorm:"'QTY'"`                                    // 提货数量
	Reqtime         time.Time `json:"reqtime"  xorm:"'REQTIME'"`                            // 更新时间
	Recivername     string    `json:"recivername"  xorm:"'RECIVERNAME'"`                    // 提货人姓名
	Cardtypeid      int32     `json:"cardtypeid"  xorm:"'CARDTYPEID'"`                      // 提货人证件类型
	Cardnum         string    `json:"cardnum"  xorm:"'CARDNUM'"`                            // 提货人证件号码
	Phonenum        string    `json:"phonenum"  xorm:"'PHONENUM'"`                          // 提货人联系方式
	Takemode        int32     `json:"takemode"  xorm:"'TAKEMODE'"`                          // 提货方式 - 2:自提 3:配送
	Address         string    `json:"address"  xorm:"'ADDRESS'"`                            // 提货人详细地址
	Takeremark      string    `json:"takeremark"  xorm:"'TAKEREMARK'"`                      // 提货备注
	Takeorderstatus int32     `json:"takeorderstatus"  xorm:"'TAKEORDERSTATUS'"`            // 提货状态 - 1:待发货 2:已发货 3:已收货
	Auditer         int32     `json:"auditer"  xorm:"'AUDITER'"`                            // 审核人
	Audittime       time.Time `json:"audittime"  xorm:"'AUDITTIME'"`                        // 审核时间
	Checkremark     string    `json:"checkremark"  xorm:"'CHECKREMARK'"`                    // 审核备注
	Tradedate       string    `json:"tradedate"  xorm:"'TRADEDATE'"`                        // 交易日(yyyyMMdd)
	Marketid        int32     `json:"marketid"  xorm:"'MARKETID'"`                          // 市场ID
	Handlestatus    int32     `json:"handlestatus"  xorm:"'HANDLESTATUS'"`                  // 处理状态
	Amount          float64   `json:"amount"  xorm:"'AMOUNT'"`                              // 提货金额
	Averageprice    float64   `json:"averageprice" xorm:"'AVERAGEPRICE'"`                   // 均价

	Goodscode    string  `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string  `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64   `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Agreeunit    float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位

	Picurls string `json:"picurls"  xorm:"'PICURLS'"` // 介绍图片[多张用逗号分隔]

	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号

	Vendorname string `json:"vendorname"  xorm:"'VENDORNAME'"` // 供应商名称
}

// GetHsbyMyPackages 获取我的包裹信息
// 输入 accountIDs string 资金账户列表
// 输入 takeOrderStatus int 提货状态 - 1:待发货 2:已发货 3:已收货
// 输出 []HsbyMyPackage 我的包裹信息
// 输出 error error
func GetHsbyMyPackages(accountIDs string, takeOrderStatus int) ([]HsbyMyPackage, error) {
	engine := db.GetEngine()

	myPackages := make([]HsbyMyPackage, 0)
	session := engine.Table("TRADE_GOODSPICKUP").
		Select(`to_char(TRADE_GOODSPICKUP.TAKEORDERID) TAKEORDERID, (DIVISION.PATHNAME || TRADE_GOODSPICKUP.ADDRESS) ADDRESS, TRADE_GOODSPICKUP.*, 
				(TRADE_GOODSPICKUP.AMOUNT/TRADE_GOODSPICKUP.QTY/GOODS.AGREEUNIT) AVERAGEPRICE, 
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HSBY_GOODSEX.PICURLS, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HSBY_SUPPLIERINFO.VENDORNAME`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = TRADE_GOODSPICKUP.GOODSID").
		Join("LEFT", "HSBY_GOODSEX", "HSBY_GOODSEX.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "GOODS.CURRENCYID = ENUMDICITEM.ENUMITEMNAME and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "HSBY_SUPPLIERINFO", "HSBY_SUPPLIERINFO.VENDORID = HSBY_GOODSEX.VENDORID").
		Join("LEFT", "DIVISION", "DIVISION.AUTOID = TRADE_GOODSPICKUP.DISTRICTID").
		Where(fmt.Sprintf("TRADE_GOODSPICKUP.ACCOUNTID in (%s)", accountIDs))
	if takeOrderStatus > 0 {
		session = session.And("TAKEORDERSTATUS = ?", takeOrderStatus)
	}
	if err := session.Find(&myPackages); err != nil {
		return nil, err
	}

	// FIXME：- 目前暂时在服务端对手机号码进行解密
	key, _ := hex.DecodeString(utils.AESSecretKey)
	for i := range myPackages {
		myPackage := &myPackages[i]

		if len(myPackage.Phonenum) > 0 {
			// 解密手机号码
			if phonenum, err := hex.DecodeString(myPackage.Phonenum); err == nil { // hex -> []byte
				if mobile, err := utils.AESDecrypt(phonenum, key); err == nil {
					myPackage.Phonenum = string(mobile)
				}
			}
		}
	}

	return myPackages, nil
}

// SetHsbyMyPackagesStatus 设置我的包裹提货状态
func SetHsbyMyPackagesStatus(takeOrderID string, accountID, status int) error {
	engine := db.GetEngine()

	sql := fmt.Sprintf("update TRADE_GOODSPICKUP set TAKEORDERSTATUS = %d where TAKEORDERID = %s and ACCOUNTID = %d", status, takeOrderID, accountID)
	_, err := engine.Exec(sql)

	return err
}

// GetHsbyProvincesAndCities 获取省市信息数组
// 参数 provinceID int 省ID，选填
// 返回 []Division 枚举信息数组
// 返回 error error
func GetHsbyProvincesAndCities(provinceID int) ([]Division, error) {
	engine := db.GetEngine()

	divisions := make([]Division, 0)
	session := engine.Where("DIVISIONLEVEL = 'province' or DIVISIONLEVEL = 'city'").
		And(`AUTOID in (
				(select DESCPROVINCEID AUTOID from HSBY_GOODSEX inner join GOODS on GOODS.GOODSID = HSBY_GOODSEX.GOODSID and GOODS.GOODSSTATUS in (2,3))
				union all
				(select DESCCITYID AUTOID from HSBY_GOODSEX inner join GOODS on GOODS.GOODSID = HSBY_GOODSEX.GOODSID and GOODS.GOODSSTATUS in (2,3))
						)`)
	if provinceID > 0 {
		session = session.And("AUTOID = ?", provinceID)
	}
	if err := session.Find(&divisions); err != nil {
		return nil, err
	}

	return divisions, nil
}

// HsbyBuyMyTradeDetail "我的订单 - 已完成"单据信息（一二级市场成交单，包括历史数据）
type HsbyBuyMyTradeDetail struct {
	Orderid   string    `json:"orderid"  xorm:"'ORDERID'" binding:"required"`     // 单号（成交单号）
	Marketid  int32     `json:"marketid"  xorm:"'MARKETID'" binding:"required"`   // 市场ID
	Goodsid   int32     `json:"goodsid"  xorm:"'GOODSID'" binding:"required"`     // 商品ID
	Accountid int64     `json:"accountid"  xorm:"'ACCOUNTID'" binding:"required"` // 账户ID[报价币种]
	Buyorsell int32     `json:"buyorsell"  xorm:"'BUYORSELL'" binding:"required"` // 买卖 - 0:买 1:卖
	Price     float64   `json:"price"  xorm:"'PRICE'"`                            // 价格
	Qty       int64     `json:"qty"  xorm:"'QTY'" binding:"required"`             // 数量
	Time      time.Time `json:"time"  xorm:"'TIME'" binding:"required"`           // 时间
	Amount    float64   `json:"amount" xorm:"'AMOUNT'"`                           // 金额 = 价格 * 数量 * 合约单位

	Goodscode    string  `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string  `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64   `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Agreeunit    float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位

	Picurls1 string `json:"picurls1"  xorm:"'PICURLS1'"` // 预售商品介绍图片[多张用逗号分隔]
	Picurls2 string `json:"picurls2"  xorm:"'PICURLS2'"` // 挂牌商品介绍图片[多张用逗号分隔]

	Trademode uint32 `json:"trademode"  xorm:"'TRADEMODE'" binding:"required"` // 交易模式 - 10:做市 13:竞价 15:通道交易 16:挂牌点选 17:仓单贸易 18:期权 19:竞拍-降价式 20:竞拍-竞价式 21:竞拍-大宗式 22:受托竞价

	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号

	Vendorname1 string `json:"vendorname1"  xorm:"'VENDORNAME1'"` // 预售商品供应商名称
	Vendorname2 string `json:"vendorname2"  xorm:"'VENDORNAME2'"` // 挂牌商品供应商名称
}

// GetHsbyBuyMyTradeDetails 获取"我的订单 - 已完成"单据信息（一二级市场成交单，包括历史数据）
// 输入 accountIDs string 资金账户列表
// 输出 []HsbyBuyMyTradeDetail "我的订单 - 已完成"单据信息
// 输出 error error
func GetHsbyBuyMyTradeDetails(accountIDs string) ([]HsbyBuyMyTradeDetail, error) {
	// 获取市场信息
	markets, err := GetMarkets()
	if err != nil {
		return nil, err
	}

	engine := db.GetEngine()
	marketIDs := "" // 我的订单包括一二级市场卖方向成交单（包括历史成交单）
	// 默认取 TradeMode = 16
	for _, v := range markets {
		if v.Trademode == 16 || v.Trademode == 71 {
			if len(marketIDs) == 0 {
				marketIDs = strconv.Itoa(int(v.Marketid))
			} else {
				marketIDs += "," + strconv.Itoa(int(v.Marketid))
			}
		}
	}

	orders := make([]HsbyBuyMyTradeDetail, 0)

	// 当前成交单
	curOrders := make([]HsbyBuyMyTradeDetail, 0)
	if err := engine.Table("TRADE_TRADEDETAIL").
		Select(`to_char(TRADE_TRADEDETAIL.TRADEID) ORDERID, 
				TRADE_TRADEDETAIL.MARKETID, TRADE_TRADEDETAIL.GOODSID, TRADE_TRADEDETAIL.ACCOUNTID, TRADE_TRADEDETAIL.BUYORSELL,
				TRADE_TRADEDETAIL.TRADEPRICE PRICE, TRADE_TRADEDETAIL.TRADEQTY QTY, TRADE_TRADEDETAIL.TRADETIME TIME, TRADE_TRADEDETAIL.TRADEAMOUNT AMOUNT, 
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HG1.PICURLS PICURLS1, HG2.PICURLS PICURLS2, 
				MARKET.TRADEMODE, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HS1.VENDORNAME VENDORNAME1, HS2.VENDORNAME VENDORNAME2`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = TRADE_TRADEDETAIL.GOODSID").
		Join("LEFT", "CPTRADE_PRESALEGOODSEX", "CPTRADE_PRESALEGOODSEX.GOODSID = TRADE_TRADEDETAIL.GOODSID").
		Join("LEFT", "HSBY_GOODSEX HG1", "HG1.GOODSID = CPTRADE_PRESALEGOODSEX.RELATEDGOODSID").
		Join("LEFT", "HSBY_GOODSEX HG2", "HG2.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "GOODS.CURRENCYID = ENUMDICITEM.ENUMITEMNAME and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET", "MARKET.MARKETID = TRADE_TRADEDETAIL.MARKETID").
		Join("LEFT", "HSBY_SUPPLIERINFO HS1", "HS1.VENDORID = HG1.VENDORID").
		Join("LEFT", "HSBY_SUPPLIERINFO HS2", "HS2.VENDORID = HG2.VENDORID").
		Where(fmt.Sprintf(`TRADE_TRADEDETAIL.BUYORSELL = 0 and TRADE_TRADEDETAIL.TRADETYPE in (1,24) 
						   and TRADE_TRADEDETAIL.ACCOUNTID in (%s)`, accountIDs)).
		And(fmt.Sprintf("TRADE_TRADEDETAIL.MARKETID in (%s)", marketIDs)).Find(&curOrders); err != nil {
		return nil, err
	}
	if len(curOrders) > 0 {
		orders = append(orders, curOrders...)
	}

	// 历史成交单
	hisOrders := make([]HsbyBuyMyTradeDetail, 0)
	if err := engine.Table("HIS_TRADE_TRADEDETAIL").
		Select(`to_char(HIS_TRADE_TRADEDETAIL.TRADEID) ORDERID, 
				HIS_TRADE_TRADEDETAIL.MARKETID, HIS_TRADE_TRADEDETAIL.GOODSID, HIS_TRADE_TRADEDETAIL.ACCOUNTID, HIS_TRADE_TRADEDETAIL.BUYORSELL,
				HIS_TRADE_TRADEDETAIL.TRADEPRICE PRICE, HIS_TRADE_TRADEDETAIL.TRADEQTY QTY, HIS_TRADE_TRADEDETAIL.TRADETIME TIME, HIS_TRADE_TRADEDETAIL.TRADEAMOUNT AMOUNT, 
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HG1.PICURLS PICURLS1, HG2.PICURLS PICURLS2, 
				MARKET.TRADEMODE, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HS1.VENDORNAME VENDORNAME1, HS2.VENDORNAME VENDORNAME2`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = HIS_TRADE_TRADEDETAIL.GOODSID").
		Join("LEFT", "CPTRADE_PRESALEGOODSEX", "CPTRADE_PRESALEGOODSEX.GOODSID = HIS_TRADE_TRADEDETAIL.GOODSID").
		Join("LEFT", "HSBY_GOODSEX HG1", "HG1.GOODSID = CPTRADE_PRESALEGOODSEX.RELATEDGOODSID").
		Join("LEFT", "HSBY_GOODSEX HG2", "HG2.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "GOODS.CURRENCYID = ENUMDICITEM.ENUMITEMNAME and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET", "MARKET.MARKETID = HIS_TRADE_TRADEDETAIL.MARKETID").
		Join("LEFT", "HSBY_SUPPLIERINFO HS1", "HS1.VENDORID = HG1.VENDORID").
		Join("LEFT", "HSBY_SUPPLIERINFO HS2", "HS2.VENDORID = HG2.VENDORID").
		Where(fmt.Sprintf(`HIS_TRADE_TRADEDETAIL.BUYORSELL = 0 and HIS_TRADE_TRADEDETAIL.TRADETYPE in (1,24) and HIS_TRADE_TRADEDETAIL.ISVALIDDATA = 1 
						   and HIS_TRADE_TRADEDETAIL.ACCOUNTID in (%s)`, accountIDs)).
		And(fmt.Sprintf("HIS_TRADE_TRADEDETAIL.MARKETID in (%s)", marketIDs)).Find(&hisOrders); err != nil {
		return nil, err
	}
	if len(hisOrders) > 0 {
		orders = append(orders, hisOrders...)
	}

	return orders, nil
}

// HsbyBuyMyPayOrder "我的订单 - 待付款"单据信息（一二级市场待付款信息）
type HsbyBuyMyPayOrder struct {
	Tradeid        string    `json:"tradeid"  xorm:"'TRADEIDSTR'" binding:"required"` // 成交单号(101+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	Tradedate      string    `json:"tradedate"  xorm:"'TRADEDATE'"`                   // 交易日(yyyyMMdd)
	Marketid       int32     `json:"marketid"  xorm:"'MARKETID'"`                     // 市场ID
	Goodsid        int32     `json:"goodsid"  xorm:"'GOODSID'"`                       // 商品ID
	Buyorderid     string    `json:"buyorderid"  xorm:"'BUYORDERIDSTR'"`              // 买方委托单号
	Buyaccountid   int64     `json:"buyaccountid"  xorm:"'BUYACCOUNTID'"`             // 买方账号ID[报价币种]
	Sellorderid    string    `json:"sellorderid"  xorm:"'SELLORDERIDSTR'"`            // 卖方委托单号
	Sellaccountid  int64     `json:"sellaccountid"  xorm:"'SELLACCOUNTID'"`           // 卖方账号ID[报价币种]
	Tradeamount    float64   `json:"tradeamount"  xorm:"'TRADEAMOUNT'"`               // 成交金额
	Tradecharge    float64   `json:"tradecharge"  xorm:"'TRADECHARGE'"`               // 成交手续费(买方)
	Payflag        int32     `json:"payflag"  xorm:"'PAYFLAG'"`                       // 付款标识 - 1:未支付 2:已支付 3:已过期 4:已撤销 5:结算过期 6:预售终止
	Createtime     time.Time `json:"createtime"  xorm:"'CREATETIME'"`                 // 创建时间
	Paytime        time.Time `json:"paytime"  xorm:"'PAYTIME'"`                       // 付款时间
	Paylimitedtime time.Time `json:"paylimitedtime"  xorm:"'PAYLIMITEDTIME'"`         // 支付期限
	Offamount      float64   `json:"offamount"  xorm:"'OFFAMOUNT'"`                   // 优惠金额
	Tradeprice     float64   `json:"tradeprice"  xorm:"'TRADEPRICE'"`                 // 成交价格
	Tradeqty       int64     `json:"tradeqty"  xorm:"'TRADEQTY'"`                     // 成交数量
	Payamount      float64   `json:"payamount"  xorm:"'PAYAMOUNT'"`                   // 支付金额 = TradeAmount + TradeCharge - OffAmount

	Goodscode    string  `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string  `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64   `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Agreeunit    float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位

	Picurls1 string `json:"picurls1"  xorm:"'PICURLS1'"` // 预售商品介绍图片[多张用逗号分隔]
	Picurls2 string `json:"picurls2"  xorm:"'PICURLS2'"` // 挂牌商品介绍图片[多张用逗号分隔]

	Trademode uint32 `json:"trademode"  xorm:"'TRADEMODE'" binding:"required"` // 交易模式 - 10:做市 13:竞价 15:通道交易 16:挂牌点选 17:仓单贸易 18:期权 19:竞拍-降价式 20:竞拍-竞价式 21:竞拍-大宗式 22:受托竞价

	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号

	Vendorname1 string `json:"vendorname1"  xorm:"'VENDORNAME1'"` // 预售商品供应商名称
	Vendorname2 string `json:"vendorname2"  xorm:"'VENDORNAME2'"` // 挂牌商品供应商名称
}

// GetHsbyBuyMyPayOrders 获取待付款信息
func GetHsbyBuyMyPayOrders(accountIDs string, buyOrderID, sellOrderID int) ([]HsbyBuyMyPayOrder, error) {
	// 获取市场信息
	markets, err := GetMarkets()
	if err != nil {
		return nil, err
	}

	engine := db.GetEngine()
	marketIDs := "" // 我的订单包括一二级市场卖方向成交单
	// 默认取 TradeMode = 16
	for _, v := range markets {
		if v.Trademode == 16 || v.Trademode == 71 || v.Trademode == 70 {
			if len(marketIDs) == 0 {
				marketIDs = strconv.Itoa(int(v.Marketid))
			} else {
				marketIDs += "," + strconv.Itoa(int(v.Marketid))
			}
		}
	}

	orders := make([]HsbyBuyMyPayOrder, 0)
	session := engine.Table("TRADE_PAYORDER TP").
		Select(`to_char(TP.TRADEID) TRADEIDSTR, to_char(TP.BUYORDERID) BUYORDERIDSTR, to_char(TP.SELLORDERID) SELLORDERIDSTR, TP.*,
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HG1.PICURLS PICURLS1, HG2.PICURLS PICURLS2, 
				MARKET.TRADEMODE, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HS1.VENDORNAME VENDORNAME1, HS2.VENDORNAME VENDORNAME2`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = TP.GOODSID").
		Join("LEFT", "CPTRADE_PRESALEGOODSEX CP", "CP.GOODSID = TP.GOODSID").
		Join("LEFT", "HSBY_GOODSEX HG1", "HG1.GOODSID = CP.RELATEDGOODSID").
		Join("LEFT", "HSBY_GOODSEX HG2", "HG2.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "GOODS.CURRENCYID = ENUMDICITEM.ENUMITEMNAME and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET", "MARKET.MARKETID = TP.MARKETID").
		Join("LEFT", "HSBY_SUPPLIERINFO HS1", "HS1.VENDORID = HG1.VENDORID").
		Join("LEFT", "HSBY_SUPPLIERINFO HS2", "HS2.VENDORID = HG2.VENDORID").
		Where(fmt.Sprintf(`TP.PAYFLAG = 1 and TP.BUYACCOUNTID in (%s)`, accountIDs)).
		And(fmt.Sprintf("TP.MARKETID in (%s)", marketIDs))
	if buyOrderID != 0 {
		session = session.And("TP.BUYORDERID = ?", buyOrderID)
	}
	if sellOrderID != 0 {
		session = session.And("TP.SELLORDERID = ?", sellOrderID)
	}
	if err := session.Find(&orders); err != nil {
		return nil, err
	}

	return orders, nil
}

// HsbyMarketInfo 海商报业相关市场信息
type HsbyMarketInfo struct {
	Marketid     int32  `json:"marketid"  xorm:"'MARKETID'" binding:"required"`         // 市场ID正常5位，前三位固定：两位表示交易模式， 一位表示交易属性(1:收益权，2：所有权) 其它特殊市场：0-系统 1-交割服务 2-账户服务3-履约服务 4-仓单服务 5-积分服务 6-银行服务
	Marketname   string `json:"marketname"  xorm:"'MARKETNAME'"`                        // 市场名称
	Trademode    int32  `json:"trademode"  xorm:"'TRADEMODE'" binding:"required"`       // 交易模式 - 10:做市 13:竞价 15:通道交易 16:挂牌点选 17:仓单贸易 18:期权 19:竞拍-降价式 20:竞拍-竞价式 21:竞拍-大宗式 22:受托竞价
	Marketstatus int32  `json:"marketstatus"  xorm:"'MARKETSTATUS'" binding:"required"` // 生效状态(ValidStatus枚举): 1:待生效 2:正常 3:注销
}

// GetHsbyMarketInfos 获取海商报业相关市场信息
func GetHsbyMarketInfos() ([]HsbyMarketInfo, error) {
	engine := db.GetEngine()

	markets := make([]HsbyMarketInfo, 0)
	if err := engine.Table("MARKET").Where("TRADEMODE in (71,16,70)").Find(&markets); err != nil {
		return nil, err
	}

	return markets, nil
}

// HsbySellCollectionOrder 我的闲置中收款信息
type HsbySellCollectionOrder struct {
	Tradeid        string    `json:"tradeid"  xorm:"'TRADEIDSTR'" binding:"required"` // 成交单号(101+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	Tradedate      string    `json:"tradedate"  xorm:"'TRADEDATE'"`                   // 交易日(yyyyMMdd)
	Marketid       int32     `json:"marketid"  xorm:"'MARKETID'"`                     // 市场ID
	Goodsid        int32     `json:"goodsid"  xorm:"'GOODSID'"`                       // 商品ID
	Buyorderid     string    `json:"buyorderid"  xorm:"'BUYORDERIDSTR'"`              // 买方委托单号
	Buyaccountid   int64     `json:"buyaccountid"  xorm:"'BUYACCOUNTID'"`             // 买方账号ID[报价币种]
	Sellorderid    string    `json:"sellorderid"  xorm:"'SELLORDERIDSTR'"`            // 卖方委托单号
	Sellaccountid  int64     `json:"sellaccountid"  xorm:"'SELLACCOUNTID'"`           // 卖方账号ID[报价币种]
	Tradeamount    float64   `json:"tradeamount"  xorm:"'TRADEAMOUNT'"`               // 成交金额
	Tradecharge    float64   `json:"tradecharge"  xorm:"'TRADECHARGE'"`               // 成交手续费(买方)
	Payflag        int32     `json:"payflag"  xorm:"'PAYFLAG'"`                       // 付款标识 - 1:未支付 2:已支付 3:已过期 4:已撤销 5:结算过期 6:预售终止
	Createtime     time.Time `json:"createtime"  xorm:"'CREATETIME'"`                 // 创建时间
	Paytime        time.Time `json:"paytime"  xorm:"'PAYTIME'"`                       // 付款时间
	Paylimitedtime time.Time `json:"paylimitedtime"  xorm:"'PAYLIMITEDTIME'"`         // 支付期限
	Offamount      float64   `json:"offamount"  xorm:"'OFFAMOUNT'"`                   // 优惠金额
	Tradeprice     float64   `json:"tradeprice"  xorm:"'TRADEPRICE'"`                 // 成交价格
	Tradeqty       int64     `json:"tradeqty"  xorm:"'TRADEQTY'"`                     // 成交数量
	Payamount      float64   `json:"payamount"  xorm:"'PAYAMOUNT'"`                   // 支付金额 = TradeAmount + TradeCharge - OffAmount

	Goodscode    string  `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string  `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64   `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Agreeunit    float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位

	Picurls string `json:"picurls"  xorm:"'PICURLS'"` // 商品介绍图片[多张用逗号分隔]

	Trademode uint32 `json:"trademode"  xorm:"'TRADEMODE'" binding:"required"` // 交易模式 - 10:做市 13:竞价 15:通道交易 16:挂牌点选 17:仓单贸易 18:期权 19:竞拍-降价式 20:竞拍-竞价式 21:竞拍-大宗式 22:受托竞价

	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号
}

// GetHsbySellCollectionOrders 获取我的闲置中待收款信息
func GetHsbySellCollectionOrders(accountIDs string) ([]HsbySellCollectionOrder, error) {
	// 获取市场信息
	markets, err := GetMarkets()
	if err != nil {
		return nil, err
	}

	engine := db.GetEngine()
	marketIDs := ""
	for _, v := range markets {
		if v.Trademode == 16 || v.Trademode == 70 {
			if len(marketIDs) == 0 {
				marketIDs = strconv.Itoa(int(v.Marketid))
			} else {
				marketIDs += "," + strconv.Itoa(int(v.Marketid))
			}
		}
	}

	orders := make([]HsbySellCollectionOrder, 0)
	session := engine.Table("TRADE_PAYORDER TP").
		Select(`to_char(TP.TRADEID) TRADEIDSTR, to_char(TP.BUYORDERID) BUYORDERIDSTR, to_char(TP.SELLORDERID) SELLORDERIDSTR, TP.*,
				G.GOODSCODE, G.GOODSNAME, G.DECIMALPLACE, G.AGREEUNIT, 
				HG.PICURLS, 
				M.TRADEMODE, 
				E.PARAM2 CURRENCYSIGN`).
		Join("LEFT", "GOODS G", "G.GOODSID = TP.GOODSID").
		Join("LEFT", "HSBY_GOODSEX HG", "HG.GOODSID = G.GOODSID").
		Join("LEFT", "ENUMDICITEM E", "G.CURRENCYID = E.ENUMITEMNAME and E.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET M", "M.MARKETID = TP.MARKETID").
		Join("LEFT", "HSBY_SUPPLIERINFO HS", "HS.VENDORID = HG.VENDORID").
		Where(fmt.Sprintf(`TP.PAYFLAG = 1 and TP.SELLACCOUNTID in (%s)`, accountIDs)).
		And(fmt.Sprintf("TP.MARKETID in (%s)", marketIDs))
	if err := session.Find(&orders); err != nil {
		return nil, err
	}

	return orders, nil
}

// HsbyMarketGoods 特卖商城商品（三级市场商场）
type HsbyMarketGoods struct {
	Orderid     string  `json:"orderid"  xorm:"'ORDERIDSTR'" binding:"required"`  // 委托单号(100+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	Marketid    int32   `json:"marketid"  xorm:"'MARKETID'" binding:"required"`   // 市场ID
	Goodsid     int32   `json:"goodsid"  xorm:"'GOODSID'" binding:"required"`     // 商品ID
	Accountid   int64   `json:"accountid"  xorm:"'ACCOUNTID'" binding:"required"` // 账户ID[报价币种]
	Buyorsell   int32   `json:"buyorsell"  xorm:"'BUYORSELL'" binding:"required"` // 买卖 - 0:买 1:卖
	Orderprice  float64 `json:"orderprice"  xorm:"'ORDERPRICE'"`                  // 委托价格
	Orderstatus int32   `json:"orderstatus"  xorm:"'ORDERSTATUS'"`                // 委托状态 - 1： 委托请求 2：待冻结 3：委托成功 4： 委托失败 5：配对成功 6： 已撤销 7：部分成交 8：已成交 9：部成部撤 10：成交失败 11：已拒绝 12:经过摘牌(先摘后挂专用-先摘后挂已摘过) 13:冻结成功(通道交易专用) 14:通道已撤 15:通道部成部撤 16:成交失败违约(荷兰式竞拍专用)

	Goodscode    string  `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string  `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64   `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Quoteminunit int64   `json:"quoteminunit"  xorm:"'QUOTEMINUNIT'"`              // 行情最小变动单位 [整数，报价小数位一起使用]
	Agreeunit    float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位

	Hotindex   int32  `json:"hotindex"  xorm:"'HOTINDEX'"`     // 景点热度
	Videourls  string `json:"videourls"  xorm:"'VIDEOURLS'"`   // 介绍视频[多张用逗号分隔]
	Picurls    string `json:"picurls"  xorm:"'PICURLS'"`       // 介绍图片[多张用逗号分隔]
	Categoryid int32  `json:"categoryid"  xorm:"'CATEGORYID'"` // 类别ID(WRCATEGORY)

	Currency     string `json:"currency" xorm:"'CURRENCY'"`         // 货币
	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号

	Trademode int32 `json:"trademode"  xorm:"'TRADEMODE'" binding:"required"` // 交易模式 - 10:做市 13:竞价 15:通道交易 16:挂牌点选 17:仓单贸易 18:期权 19:竞拍-降价式 20:竞拍-竞价式 21:竞拍-大宗式 22:受托竞价

	Customername string `json:"customername"  xorm:"'CUSTOMERNAME'"` // 卖家名称

	HasCoupon bool `json:"hascoupon" xorm:"-"` // 是否可用优惠卷

	SellUserID int `json:"sellUserID" xorm:"-"` // 卖方UserID
}

// GetHsbyMarketGoodses 获取商城商品列表（三级商城）
func GetHsbyMarketGoodses(marketIDs string, accountID, categoryID int, goodsIDs string, couponTypeID int) ([]HsbyMarketGoods, error) {
	engine := db.GetEngine()

	// 获取优惠卷类型信息
	var couponType Coupontype
	if _, err := engine.Where("ISVALID = 1 and COUPONTYPEID = ?", couponTypeID).Get(&couponType); err != nil {
		return nil, err
	}

	orders := make([]HsbyMarketGoods, 0)
	// 与挂牌点选不一样的是商城是以委托单为主表；已经卖完的委托单不显示
	session := engine.Table("TRADE_ORDERDETAIL T").
		Select(`to_char(T.ORDERID) ORDERIDSTR, T.*, 
				G.GOODSCODE, G.GOODSNAME, G.DECIMALPLACE, G.QUOTEMINUNIT, G.AGREEUNIT, 
				GX.HOTINDEX, GX.PICURLS, GX.CATEGORYID, GX.GOODSDESC, 
				E.ENUMDICNAME CURRENCY, E.PARAM2 CURRENCYSIGN, 
				M.TRADEMODE, 
				U.CUSTOMERNAME`).
		Join("LEFT", "GOODS G", "G.GOODSID = T.GOODSID").
		Join("LEFT", "HSBY_GOODSEX GX", "GX.GOODSID = T.GOODSID").
		Join("LEFT", "ENUMDICITEM E", "E.ENUMITEMNAME = G.CURRENCYID and E.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET M", "M.MARKETID = T.MARKETID").
		Join("LEFT", "TAACCOUNT TA", "TA.ACCOUNTID = T.ACCOUNTID").
		Join("LEFT", "USERINFO U", "U.USERID = TA.RELATEDUSERID").
		Where(fmt.Sprintf("T.MARKETID in (%s)", marketIDs)).
		And("T.ORDERSTATUS in (3,7) and T.BUYORSELL = 1 and (T.ORDERQTY - T.TRADEQTY - T.CANCELQTY) > 0")
	if categoryID != 0 {
		session = session.And("GX.CATEGORYID = ?", categoryID)
	}
	if len(goodsIDs) > 0 {
		session = session.And(fmt.Sprintf("G.GOODSID in (%s)", goodsIDs))
	}
	if couponTypeID > 0 {
		if couponType.Coupontypeid == 0 {
			// 没有查询到对应的优惠卷，直接返回空数组
			return make([]HsbyMarketGoods, 0), nil
		}

		// 优惠卷特定商品
		if couponType.Limitedflag == 1 {
			// 去掉头尾逗号
			limitedGoodsIDs := couponType.Limitedgoodsids
			if strings.HasPrefix(limitedGoodsIDs, ",") && strings.HasSuffix(limitedGoodsIDs, ",") {
				limitedGoodsIDs = limitedGoodsIDs[1 : len(limitedGoodsIDs)-1]
			}
			session = session.And(fmt.Sprintf("T.GOODSID in (%s)", limitedGoodsIDs))
		}

		// 优惠卷特定卖家
		if couponType.Isgeneral == 0 {
			// 去掉头尾逗号
			userScope := couponType.Userscope
			if strings.HasPrefix(userScope, ",") && strings.HasSuffix(userScope, ",") {
				userScope = userScope[1 : len(userScope)-1]
			}
			// 查询对应的卖家资金账户信息
			taAccounts := make([]Taaccount, 0)
			if err := engine.Where(fmt.Sprintf("RELATEDUSERID in (%s)", userScope)).Find(&taAccounts); err != nil {
				return nil, err
			}
			sellAccountIDs := ""
			for _, v := range taAccounts {
				if len(sellAccountIDs) == 0 {
					sellAccountIDs = strconv.Itoa(int(v.Accountid))
				} else {
					sellAccountIDs += "," + strconv.Itoa(int(v.Accountid))
				}
			}
			session = session.And(fmt.Sprintf("T.ACCOUNTID in (%s)", sellAccountIDs))
		}
	}
	if err := session.Find(&orders); err != nil {
		return nil, err
	}

	// 获取当前账户的优惠卷
	type myCouponPosition struct {
		Accountid    int64 `json:"accountid"  xorm:"'ACCOUNTID'" binding:"required"`       // 资金账户ID
		Coupontypeid int32 `json:"coupontypeid"  xorm:"'COUPONTYPEID'" binding:"required"` // 优惠券类型ID
		Curqty       int64 `json:"curqty"  xorm:"'CURQTY'"`                                // 期末数量
		Curfreezeqty int64 `json:"curfreezeqty"  xorm:"'CURFREEZEQTY'"`                    // 期末冻结数量

		Limitedflag     int32  `json:"limitedflag"  xorm:"'LIMITEDFLAG'"`         // 是否指定商品 - 0:不限 1:限制
		Limitedgoodsids string `json:"limitedgoodsids"  xorm:"'LIMITEDGOODSIDS'"` // 指定商品IDs[逗号分隔,前后加逗号]
		Isgeneral       int32  `json:"isgeneral"  xorm:"'ISGENERAL'"`             // 是否通用券 - 0:否 1:是
		Userscope       string `json:"userscope"  xorm:"'USERSCOPE'"`             // 卖家范围(用户ID，逗号分隔,前后加逗号) [IsGeneral =0时使用]
	}
	myCouponPositions := make([]myCouponPosition, 0)
	if accountID != 0 {
		if err := engine.Table("COUPONPOSITION C").
			Select(`C.ACCOUNTID, C.COUPONTYPEID, C.CURQTY, C.CURFREEZEQTY,
				CT.LIMITEDFLAG, CT.LIMITEDGOODSIDS, CT.ISGENERAL, CT.USERSCOPE`).
			Join("INNER", "COUPONTYPE CT", "CT.COUPONTYPEID = C.COUPONTYPEID").
			Where("C.ACCOUNTID = ?", accountID).Find(&myCouponPositions); err != nil {
			return nil, err
		}
	}

	// 是否有优惠卷可用
	if len(orders) > 0 && len(myCouponPositions) > 0 {
		for _, coupon := range myCouponPositions {
			if coupon.Limitedflag == 0 && coupon.Isgeneral == 1 {
				// 有不指定商品的通用卷则所有委托单都可以用卷
				for i := range orders {
					order := &orders[i]
					order.HasCoupon = true
				}
				break
			} else {
				for i := range orders {
					order := &orders[i]

					// 获取卖家UserID
					userInfo, err := GetUserInfoByAccountID(int(order.Accountid))
					if err != nil {
						continue
					}
					order.SellUserID = int(userInfo.Userid)
					// order.Customername = userInfo.Customername

					tmpGoodsID := fmt.Sprintf(",%d,", order.Goodsid)
					tmpUserID := fmt.Sprintf(",%d,", userInfo.Userid)

					// 优惠卷是否可用于商品
					isRightGoods := false
					if coupon.Limitedflag == 0 {
						isRightGoods = true
					} else {
						if strings.Contains(coupon.Limitedgoodsids, tmpGoodsID) {
							isRightGoods = true
						}
					}
					// 优惠卷是否可用于卖家
					isRightAccount := false
					if coupon.Isgeneral == 1 {
						isRightAccount = true
					} else {
						if strings.Contains(coupon.Userscope, tmpUserID) {
							isRightAccount = true
						}
					}

					if isRightGoods && isRightAccount {
						order.HasCoupon = true
					}
				}
			}
		}
	}

	return orders, nil
}

// HsbyMarketGoodsDetail 特卖商城商品（三级市场商场）
type HsbyMarketGoodsDetail struct {
	Orderid     string  `json:"orderid"  xorm:"'ORDERIDSTR'" binding:"required"`  // 委托单号(100+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	Marketid    int32   `json:"marketid"  xorm:"'MARKETID'" binding:"required"`   // 市场ID
	Goodsid     int32   `json:"goodsid"  xorm:"'GOODSID'" binding:"required"`     // 商品ID
	Accountid   int64   `json:"accountid"  xorm:"'ACCOUNTID'" binding:"required"` // 账户ID[报价币种]
	Buyorsell   int32   `json:"buyorsell"  xorm:"'BUYORSELL'" binding:"required"` // 买卖 - 0:买 1:卖
	Orderprice  float64 `json:"orderprice"  xorm:"'ORDERPRICE'"`                  // 委托价格
	Orderqty    int64   `json:"orderqty"  xorm:"'ORDERQTY'" binding:"required"`   // 委托数量
	Tradeqty    int64   `json:"tradeqty"  xorm:"'TRADEQTY'"`                      // 成交数量
	Cancelqty   int64   `json:"cancelqty"  xorm:"'CANCELQTY'"`                    // 撤单数量
	Orderstatus int32   `json:"orderstatus"  xorm:"'ORDERSTATUS'"`                // 委托状态 - 1： 委托请求 2：待冻结 3：委托成功 4： 委托失败 5：配对成功 6： 已撤销 7：部分成交 8：已成交 9：部成部撤 10：成交失败 11：已拒绝 12:经过摘牌(先摘后挂专用-先摘后挂已摘过) 13:冻结成功(通道交易专用) 14:通道已撤 15:通道部成部撤 16:成交失败违约(荷兰式竞拍专用)

	Goodscode    string  `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string  `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64   `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Quoteminunit int64   `json:"quoteminunit"  xorm:"'QUOTEMINUNIT'"`              // 行情最小变动单位 [整数，报价小数位一起使用]
	Agreeunit    float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位

	Hotindex   int32  `json:"hotindex"  xorm:"'HOTINDEX'"`     // 景点热度
	Videourls  string `json:"videourls"  xorm:"'VIDEOURLS'"`   // 介绍视频[多张用逗号分隔]
	Picurls    string `json:"picurls"  xorm:"'PICURLS'"`       // 介绍图片[多张用逗号分隔]
	Categoryid int32  `json:"categoryid"  xorm:"'CATEGORYID'"` // 类别ID(WRCATEGORY)
	Goodsdesc  string `json:"goodsdesc"  xorm:"'GOODSDESC'"`   // 商品详情

	Currency     string `json:"currency" xorm:"'CURRENCY'"`         // 货币
	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号

	Trademode int32 `json:"trademode"  xorm:"'TRADEMODE'" binding:"required"` // 交易模式 - 10:做市 13:竞价 15:通道交易 16:挂牌点选 17:仓单贸易 18:期权 19:竞拍-降价式 20:竞拍-竞价式 21:竞拍-大宗式 22:受托竞价

	Vendorname  string `json:"vendorname"  xorm:"'VENDORNAME'"`   // 供应商名称
	Vendorattr  string `json:"vendorattr"  xorm:"'VENDORATTR'"`   // 供应商附件(多张，逗号分隔)
	Vendorphone string `json:"vendorphone"  xorm:"'VENDORPHONE'"` // 供应商客服电话

	Customername string `json:"customername"  xorm:"'CUSTOMERNAME'"` // 卖家名称

	SellUserID int `json:"sellUserID" xorm:"SELLUSERID"` // 卖方UserID

	LotSize   int `json:"lotsize" xorm:"-"`      // 手数最小变动单位
	Buymaxqty int `json:"buymaxqty"  xorm:"'-'"` // 购买上限 [71] - 0为不限
}

// GetHsbyMarketGoodsDetail 获取商城商品详情（三级商城）
func GetHsbyMarketGoodsDetail(orderID, accountID int) (*HsbyMarketGoodsDetail, error) {
	engine := db.GetEngine()

	orders := make([]HsbyMarketGoodsDetail, 0)
	// 与挂牌点选不一样的是商城是以委托单为主表
	session := engine.Table("TRADE_ORDERDETAIL T").
		Select(`to_char(T.ORDERID) ORDERIDSTR, T.*, 
				G.GOODSCODE, G.GOODSNAME, G.DECIMALPLACE, G.QUOTEMINUNIT, G.AGREEUNIT, 
				GX.HOTINDEX, GX.VIDEOURLS, GX.PICURLS, GX.CATEGORYID, GX.GOODSDESC, 
				E.ENUMDICNAME CURRENCY, E.PARAM2 CURRENCYSIGN, 
				M.TRADEMODE, 
				H.VENDORNAME, H.VENDORATTR, H.VENDORPHONE, 
				U.USERID SELLUSERID, U.CUSTOMERNAME`).
		Join("LEFT", "GOODS G", "G.GOODSID = T.GOODSID").
		Join("LEFT", "HSBY_GOODSEX GX", "GX.GOODSID = T.GOODSID").
		Join("LEFT", "ENUMDICITEM E", "E.ENUMITEMNAME = G.CURRENCYID and E.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET M", "M.MARKETID = T.MARKETID").
		Join("LEFT", "HSBY_SUPPLIERINFO H", "H.VENDORID = GX.VENDORID").
		Join("LEFT", "TAACCOUNT TA", "TA.ACCOUNTID = T.ACCOUNTID").
		Join("LEFT", "USERINFO U", "U.USERID = TA.RELATEDUSERID").
		Where("T.ORDERID = ?", orderID)
	if err := session.Find(&orders); err != nil {
		return nil, err
	}
	// 无目标商品
	if len(orders) == 0 {
		return nil, nil
	}
	hsbyMarketGoodsDetail := orders[0]
	// 最小交易手数在上层进行设置，这里暂设置为1
	hsbyMarketGoodsDetail.LotSize = 1

	return &hsbyMarketGoodsDetail, nil
}

// MyCoupon 我的优惠卷
type MyCoupon struct {
	Accountid     int64  `json:"accountid"  xorm:"'ACCOUNTID'" binding:"required"`          // 资金账户ID
	Coupontypeid  string `json:"coupontypeid"  xorm:"'COUPONTYPEIDSTR'" binding:"required"` // 优惠券类型ID
	Userid        int64  `json:"userid"  xorm:"'USERID'"`                                   // 用户ID
	Oriqty        int64  `json:"oriqty"  xorm:"'ORIQTY'"`                                   // 期初数量
	Orifreezeqty  int64  `json:"orifreezeqty"  xorm:"'ORIFREEZEQTY'"`                       // 期初冻结数量
	Curqty        int64  `json:"curqty"  xorm:"'CURQTY'"`                                   // 期末数量
	Curfreezeqty  int64  `json:"curfreezeqty"  xorm:"'CURFREEZEQTY'"`                       // 期末冻结数量
	Todayincrease int64  `json:"todayincrease"  xorm:"'TODAYINCREASE'"`                     // 今日增加
	Todaydecrease int64  `json:"todaydecrease"  xorm:"'TODAYDECREASE'"`                     // 今日减少

	Areauserid      int64   `json:"areauserid"  xorm:"'AREAUSERID'"`           // 所属机构
	Couponname      string  `json:"couponname"  xorm:"'COUPONNAME'"`           // 优惠券名称
	Couponcategroy  int32   `json:"couponcategroy"  xorm:"'COUPONCATEGROY'"`   // 种类 - 1:现金券 2:折扣券 3:折扣券(单张)
	Conditionvalue  float64 `json:"conditionvalue"  xorm:"'CONDITIONVALUE'"`   // 条件阈值(可为0)
	Couponvalue     float64 `json:"couponvalue"  xorm:"'COUPONVALUE'"`         // 面值[1:现金券 - 抵扣值 2:折扣券-折扣值]
	Limitedflag     int32   `json:"limitedflag"  xorm:"'LIMITEDFLAG'"`         // 是否指定商品 - 0:不限 1:限制
	Limitedgoodsids string  `json:"limitedgoodsids"  xorm:"'LIMITEDGOODSIDS'"` // 指定商品IDs[逗号分隔,前后加逗号]
	Isgeneral       int32   `json:"isgeneral"  xorm:"'ISGENERAL'"`             // 是否通用券 - 0:否 1:是
	Userscope       string  `json:"userscope"  xorm:"'USERSCOPE'"`             // 卖家范围(用户ID，逗号分隔,前后加逗号) [IsGeneral =0时使用]

	IsUnusable bool `json:"isunusable" xorm:"-"` // 是否不可用
	ReasonType int  `json:"reasontype"`          // 不可用原因 - 0:未确认 1:不可用于此商品 2:不可用于此卖家
}

// GetMyCoupons 获取我的优惠卷信息
func GetMyCoupons(accountIDs string, goodsID, sellUserID int) ([]MyCoupon, error) {
	engine := db.GetEngine()

	myCoupons := make([]MyCoupon, 0)
	session := engine.Table("COUPONPOSITION CP").
		Select("to_char(CP.COUPONTYPEID) COUPONTYPEIDSTR, CP.*").
		Join("INNER", "COUPONTYPE CT", "CT.COUPONTYPEID = CP.COUPONTYPEID").
		Where(fmt.Sprintf("CP.ACCOUNTID in (%s)", accountIDs))
	if err := session.Find(&myCoupons); err != nil {
		return nil, err
	}

	// 如果传入了商品ID和卖方UserID，则判断优惠卷是否可用
	if goodsID != 0 && sellUserID != 0 && len(myCoupons) > 0 {
		for i := range myCoupons {
			myCoupon := &myCoupons[i]

			// 优惠卷是否可用于商品
			isRightGoods := false
			if myCoupon.Limitedflag == 0 {
				isRightGoods = true
			} else {
				if strings.Contains(myCoupon.Limitedgoodsids, fmt.Sprintf(",%d,", goodsID)) {
					isRightGoods = true
				}
			}
			// 优惠卷是否可用于卖家
			isRightAccount := false
			if myCoupon.Isgeneral == 1 {
				isRightAccount = true
			} else {
				if strings.Contains(myCoupon.Userscope, fmt.Sprintf(",%d,", sellUserID)) {
					isRightAccount = true
				}
			}

			if !isRightGoods {
				myCoupon.IsUnusable = true
				myCoupon.ReasonType = 1
			}
			if !isRightAccount {
				myCoupon.IsUnusable = true
				myCoupon.ReasonType = 2
			}
		}
	}

	return myCoupons, nil
}

// MyCouponHold 我的优惠卷持仓
type MyCouponHold struct {
	Couponholdid    string    `json:"couponholdid"  xorm:"'COUPONHOLDIDSTR'" binding:"required"` // 优惠券持仓ID(229+Unix秒时间戳(10位)+xxxxxx)
	Giveapplyid     int64     `json:"giveapplyid"  xorm:"'GIVEAPPLYID'"`                         // 发放申请ID(SEQ_COUPONGIVEAPPLY)
	Accountid       int64     `json:"accountid"  xorm:"'ACCOUNTID'"`                             // 资金账户ID
	Coupontypeid    string    `json:"coupontypeid"  xorm:"'COUPONTYPEIDSTR'"`                    // 优惠券类型ID - SEQ_COUPONTYPE
	Couponcategroy  int32     `json:"couponcategroy"  xorm:"'COUPONCATEGROY'"`                   // 种类 - 1:现金券 2:折扣券 3:折扣券(单个商品)
	Conditionvalue  float64   `json:"conditionvalue"  xorm:"'CONDITIONVALUE'"`                   // 条件阈值(可为0)
	Couponvalue     float64   `json:"couponvalue"  xorm:"'COUPONVALUE'"`                         // 面值[1:现金券 - 抵扣值 2:折扣券-折扣值]
	Limitedflag     int32     `json:"limitedflag"  xorm:"'LIMITEDFLAG'"`                         // 是否指定商品 - 0:不限 1:限制
	Limitedgoodsids string    `json:"limitedgoodsids"  xorm:"'LIMITEDGOODSIDS'"`                 // 指定商品IDs[逗号分隔]
	Isgeneral       int32     `json:"isgeneral"  xorm:"'ISGENERAL'"`                             // 是否通用券 - 0:否 1:是
	Userscope       string    `json:"userscope"  xorm:"'USERSCOPE'"`                             // 卖家范围(用户ID，逗号分隔) [IsGeneral =0时使用]
	Userid          int64     `json:"userid"  xorm:"'USERID'"`                                   // 用户ID
	Qty             int64     `json:"qty"  xorm:"'QTY'"`                                         // 数量(按1平铺)
	Startdate       time.Time `json:"startdate"  xorm:"'STARTDATE'"`                             // 开始日期
	Holdstatus      int32     `json:"holdstatus"  xorm:"'HOLDSTATUS'"`                           // 持仓状态 - 1:未生效 2:已生效 3:已使用 4:已过期
	Enddate         time.Time `json:"enddate"  xorm:"'ENDDATE'"`                                 // 结束日期
	Createtime      time.Time `json:"createtime"  xorm:"'CREATETIME'"`                           // 创建时间

	Couponname string `json:"couponname"  xorm:"'COUPONNAME'"` // 优惠券名称
}

// GetMyCouponHolds 获取优惠卷明细
func GetMyCouponHolds(accountIDs string, holdStatus string) ([]MyCouponHold, error) {
	engine := db.GetEngine()

	myCouponHolds := make([]MyCouponHold, 0)
	session := engine.Table("COUPONHOLD CH").
		Select(`to_char(CH.COUPONHOLDID) COUPONHOLDIDSTR, to_char(CH.COUPONTYPEID) COUPONTYPEIDSTR, CH.*, CT.COUPONNAME`).
		Join("INNER", "COUPONTYPE CT", "CT.COUPONTYPEID = CH.COUPONTYPEID").
		Where(fmt.Sprintf("CH.ACCOUNTID in (%s)", accountIDs))
	if len(holdStatus) > 0 {
		session = session.And(fmt.Sprintf("CH.HOLDSTATUS in (%s)", holdStatus))
	}
	if err := session.Find(&myCouponHolds); err != nil {
		return nil, err
	}

	return myCouponHolds, nil
}

// MyUsedCoupon 已使用优惠卷
type MyUsedCoupon struct {
	Orderid        string    `json:"orderid"  xorm:"'ORDERIDSTR'" binding:"required"`           // 委托单号(100+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	Coupontypeid   string    `json:"coupontypeid"  xorm:"'COUPONTYPEIDSTR'" binding:"required"` // 优惠券类型ID(买方)
	Accountid      int64     `json:"accountid"  xorm:"'ACCOUNTID'"`                             // 资金账户ID(买方)
	Usedqty        int64     `json:"usedqty"  xorm:"'USEDQTY'"`                                 // 使用数量
	Couponcategroy int32     `json:"couponcategroy"  xorm:"'COUPONCATEGROY'"`                   // 种类 - 1:现金券 2:折扣券
	Conditionvalue float64   `json:"conditionvalue"  xorm:"'CONDITIONVALUE'"`                   // 条件阈值(可为0)
	Couponvalue    float64   `json:"couponvalue"  xorm:"'COUPONVALUE'"`                         // 面值[1:现金券 - 抵扣值 2:折扣券-折扣值(0-100)]
	Sellaccountid  int64     `json:"sellaccountid"  xorm:"'SELLACCOUNTID'"`                     // 资金账户ID(卖方)
	Marketid       int32     `json:"marketid"  xorm:"'MARKETID'"`                               // 市场ID
	Goodsid        int32     `json:"goodsid"  xorm:"'GOODSID'"`                                 // 商品ID
	Tradeid        string    `json:"tradeid"  xorm:"'TRADEIDSTR'"`                              // 成交单号(101+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	Tradeamount    float64   `json:"tradeamount"  xorm:"'TRADEAMOUNT'"`                         // 成交金额
	Offamount      float64   `json:"offamount"  xorm:"'OFFAMOUNT'"`                             // 优惠金额
	Handlestatus   int32     `json:"handlestatus"  xorm:"'HANDLESTATUS'"`                       // 处理状态
	Createtime     time.Time `json:"createtime"  xorm:"'CREATETIME'"`                           // 创建时间

	Couponname string `json:"couponname"  xorm:"'COUPONNAME'"` // 优惠券名称
}

// GetMyUsedCoupon 获取已使用优惠卷
func GetMyUsedCoupon(accountIDs string) ([]MyUsedCoupon, error) {
	engine := db.GetEngine()

	myUsedCoupons := make([]MyUsedCoupon, 0)
	if err := engine.Table("TRADE_ORDERCOUPON T").
		Select(`to_char(T.ORDERID) ORDERIDSTR, to_char(T.COUPONTYPEID) COUPONTYPEIDSTR, to_char(T.TRADEID) TRADEIDSTR, T.*, 
				C.COUPONNAME`).
		Join("INNER", "COUPONTYPE C", "C.COUPONTYPEID = T.COUPONTYPEID").
		Where(fmt.Sprintf("T.ACCOUNTID in (%s)", accountIDs)).
		Desc("T.CREATETIME").
		Find(&myUsedCoupons); err != nil {
		return nil, err
	}

	return myUsedCoupons, nil
}