MTP20_IF/models/sbyj.go

package models

import (
	"fmt"
	"mtp2_if/db"
	"mtp2_if/mtpcache"
	"mtp2_if/pb"
	"mtp2_if/rediscli"
	"sort"
	"time"

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

type TouristGoods 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"`      // 商品名称
	Marketid              int64     `json:"marketid"  xorm:"'MARKETID'" binding:"required"`        // 所属市场ID
	Goodsgroupid          int64     `json:"goodsgroupid"  xorm:"'GOODSGROUPID'"`                   // 所属商品组ID
	Goodsstatus           int64     `json:"goodsstatus"  xorm:"'GOODSSTATUS'"`                     // 商品状态- 1:待审核 2:未上市 3:上市 4:已注销 5:审核拒绝 6:退市 7:待退市
	Currencyid            int64     `json:"currencyid"  xorm:"'CURRENCYID'"`                       // 报价货币ID
	Goodunitid            int64     `json:"goodunitid"  xorm:"'GOODUNITID'"`                       // 报价单位ID
	Agreeunit             float64   `json:"agreeunit"  xorm:"'AGREEUNIT'"`                         // 合约单位
	Decimalplace          int64     `json:"decimalplace"  xorm:"'DECIMALPLACE'"`                   // 报价小数位
	Listingdate           time.Time `json:"listingdate"  xorm:"'LISTINGDATE'"`                     // 交易开始日期
	Lasttradedate         time.Time `json:"lasttradedate"  xorm:"'LASTTRADEDATE'"`                 // 最后交易日期(状态：待退市)
	Delistingdate         time.Time `json:"delistingdate"  xorm:"'DELISTINGDATE'"`                 // 商品退市时间(状态：退市) -- 已作废
	Deliveryflag          int64     `json:"deliveryflag"  xorm:"'DELIVERYFLAG'"`                   // 交割标志 - 0:不可交割  1:可交割
	Hasquoter             int64     `json:"hasquoter"  xorm:"'HASQUOTER'"`                         // 是否有报价商 - 0:无报价商 1:有报价商
	Hqprotecttime         int64     `json:"hqprotecttime"  xorm:"'HQPROTECTTIME'"`                 // 行情保护时间(秒)
	Quoteshowtype         int64     `json:"quoteshowtype"  xorm:"'QUOTESHOWTYPE'"`                 // 行情报价类型: 1:成交价 2:买卖中间价 3:含买价 4:含卖价做市模式固定为3:含买价
	Quoteshowtypeinterval int64     `json:"quoteshowtypeinterval"  xorm:"'QUOTESHOWTYPEINTERVAL'"` // 行情报价间隔时间(秒)(成交价时为0)
	Modifystatus          int64     `json:"modifystatus"  xorm:"'MODIFYSTATUS'"`                   // 变更状态 - 1:未变更 2:变更中 3:待审核 4:已审核
	Goodstradetype        int64     `json:"goodstradetype"  xorm:"'GOODSTRADETYPE'"`               // 商品交易权限类型 - 1:可建可平 3:不可建可平
	Creatorid             int64     `json:"creatorid"  xorm:"'CREATORID'"`                         // 创建人
	Createtime            time.Time `json:"createtime"  xorm:"'CREATETIME'"`                       // 创建时间
	Auditaccountid        int64     `json:"auditaccountid"  xorm:"'AUDITACCOUNTID'"`               // 审核操作员账号
	Audittime             time.Time `json:"audittime"  xorm:"'AUDITTIME'"`                         // 审核时间
	Modifytime            time.Time `json:"modifytime"  xorm:"'MODIFYTIME'"`                       // 修改时间
	Modifierid            int64     `json:"modifierid"  xorm:"'MODIFIERID'"`                       // 修改人
	Cancelaccountid       int64     `json:"cancelaccountid"  xorm:"'CANCELACCOUNTID'"`             // 注销操作员账号
	Remark                string    `json:"remark"  xorm:"'REMARK'"`                               // 备注
	Canceltime            time.Time `json:"canceltime"  xorm:"'CANCELTIME'"`                       // 注销时间
	Delistingmode         int64     `json:"delistingmode"  xorm:"'DELISTINGMODE'"`                 // 退市方式 - 1:退市平仓 2:退市交收 3:不处理(仅期权\币币兑换)
	Forceclosemode        int64     `json:"forceclosemode"  xorm:"'FORCECLOSEMODE'"`               // 定期强平方式 - 1:无 2:每日 3:每周 4:每月[收益权]
	Forceclosevalue       int64     `json:"forceclosevalue"  xorm:"'FORCECLOSEVALUE'"`             // 定期强平参数 [收益权]
	Cutmode               int64     `json:"cutmode"  xorm:"'CUTMODE'"`                             // 斩仓方式 - 1:不斩仓 2:自动斩仓 3:半自动斩仓
	Quoteminunit          int64     `json:"quoteminunit"  xorm:"'QUOTEMINUNIT'"`                   // 行情最小变动单位 [整数，报价小数位一起使用]
	Isbuylimited          int64     `json:"isbuylimited"  xorm:"'ISBUYLIMITED'"`                   // 是否限制建仓量 - 0:不限制 1:限制
	Innerdealmode         int64     `json:"innerdealmode"  xorm:"'INNERDEALMODE'"`                 // 内部成交方式[通道交易] - 1:净头寸 2:开平 3:平今
	Outerdealmode         int64     `json:"outerdealmode"  xorm:"'OUTERDEALMODE'"`                 // 外部成交方式[通道交易]- 1:净头寸 2:开平 3:平今
	Closepricemode        int64     `json:"closepricemode"  xorm:"'CLOSEPRICEMODE'"`               // 强平价格方式 - 1:市价 2:最新价 3:涨跌停（未实现）
	Closepriceparam       float64   `json:"closepriceparam"  xorm:"'CLOSEPRICEPARAM'"`             // 强平最新价浮动比例 - 方式为2时使用  (<1)买 上浮 (1+x)*最新价卖 下浮 (1-x)*最新价
	Qtydecimalplace       int64     `json:"qtydecimalplace"  xorm:"'QTYDECIMALPLACE'"`             // 成交量小数位
	Goodscurrencyid       int64     `json:"goodscurrencyid"  xorm:"'GOODSCURRENCYID'"`             // 合约货币ID
	Goodsquotetype        int64     `json:"goodsquotetype"  xorm:"'GOODSQUOTETYPE'"`               // 合约报价类型: 1-直接报价  2-间接报价
	Quotegear             int64     `json:"quotegear"  xorm:"'QUOTEGEAR'"`                         // 行情档位(1-10)
	Outgoodscode          string    `json:"outgoodscode"  xorm:"'OUTGOODSCODE'"`                   // 商品代码(外部)
	Isvisible             int32     `json:"isvisible"  xorm:"ISVISIBLE"`                           // 游客是否可见 - 0:不可见 1:可见
	Areauserid            int64     `json:"areauserid"  xorm:"AREAUSERID"`                         // 所属机构
	Pictureurl            string    `json:"pictureurl"  xorm:"PICTUREURL"`                         // 商品图片

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

func GetTouristGoods(tradeModes []int) (goods []TouristGoods, err error) {
	goods = make([]TouristGoods, 0)
	session := db.GetEngine().Table("GOODS G").
		Select("G.*, M.TRADEMODE").
		Join("LEFT", "MARKET M", "M.MARKETID = G.MARKETID").
		Where("G.GOODSSTATUS in (3, 7)").In("M.TRADEMODE", tradeModes).OrderBy("G.GOODSCODE")

	err = session.Find(&goods)

	return
}

// TradeHolderDetailEx 交易持仓扩展表
type TradeHolderDetailEx struct {
	TradeID           uint64  `json:"tradeID"`           // 成交单号(101+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	BuyOrSell         uint32  `json:"buyOrSell"`         // 方向 - 0:买 1:卖
	TradeDate         string  `json:"tradeDate"`         // 交易日(yyyyMMdd)
	MarketID          uint32  `json:"marketID"`          // 市场ID
	GoodsID           uint32  `json:"goodsID"`           // 商品ID
	UserID            uint32  `json:"userID"`            // 用户ID
	AccountID         uint64  `json:"accountID"`         // 账号ID
	MatchUserID       uint32  `json:"matchUserID"`       // 对手用户ID
	MatchAccountID    uint64  `json:"matchAccountID"`    // 对手账号ID
	OpenQty           uint64  `json:"openQty"`           // 建仓数量
	TradeAmount       float64 `json:"tradeAmount"`       // 成交金额
	OpenPrice         float64 `json:"openPrice"`         // 建仓价格
	HolderQty         uint64  `json:"holderQty"`         // 持仓数量
	HolderAmount      float64 `json:"holderAmount"`      // 持仓金额
	HolderPrice       float64 `json:"holderPrice"`       // 持仓价格
	FreezeQty         uint64  `json:"freezeQty"`         // 冻结数量
	DeliveryQty       uint64  `json:"deliveryQty"`       // 交收手数(已交收)
	HoldDays          uint64  `json:"holdDays"`          // 持仓天数
	PayedDeposit      float64 `json:"payedDeposit"`      // 已付定金
	RestockDeposit    float64 `json:"restockDeposit"`    // 补充定金
	LateFeeDays       uint64  `json:"lateFeeDays"`       // 滞纳金起计天数
	LateFeeAlgorithm  uint32  `json:"lateFeeAlgorithm"`  // 滞纳金收取方式 1：比率 2：固定
	LateFeeValue      float64 `json:"lateFeeValue"`      // 滞纳金收取值
	CallAteFee        float64 `json:"callAteFee"`        // 已计滞纳金
	PromptDepositRate float64 `json:"promptDepositRate"` // 提示定金率
	CutDepositRate    float64 `json:"cutDepositRate"`    // 斩仓定金率
	PromptPrice       float64 `json:"promptPrice"`       // 提示价格
	CutPrice          float64 `json:"cutPrice"`          // 斩仓价格
	ClosePL           float64 `json:"closePL"`           // 平仓盈亏
	FloatPL           float64 `json:"floatPL"`           // 浮动盈亏
	DepositRate       float64 `json:"depositRate"`       // 订单定金率
	RefundableDeposit float64 `json:"refundableDeposit"` // 可退定金
}

// RedisTradeHolderDetailEx redis存储交易持仓扩展表
type RedisTradeHolderDetailEx struct {
	THDetailEx        TradeHolderDetailEx `json:"tHDetailEx"`        // 交易持仓扩展表记录
	FloatPL           float64             `json:"floatPL"`           // 浮动盈亏
	DepositRate       float64             `json:"depositRate"`       // 订单定金率
	RefundableDeposit float64             `json:"refundableDeposit"` // 可退定金
	GoodsCode         string              `json:"goodsCode"`         // 商品代码
	GoodsName         string              `json:"goodsName"`         // 商品名称
	GoodsUnitID       uint32              `json:"goodsUnitID"`       // 单位
	AgreeUnit         float64             `json:"agreeUnit"`         // 合约单位
	DecimalPlace      uint32              `json:"decimalPlace"`      // 小数位位数
	QuoteMinUnit      uint32              `json:"quoteMinUnit"`      // 行情最小变动单位

	GoodsUnit string `json:"goodsUnit"` // 单位名称
}

type RedisTradeHolderDetailExArray []RedisTradeHolderDetailEx

func (s RedisTradeHolderDetailExArray) Len() int { return len(s) }
func (s RedisTradeHolderDetailExArray) Less(i, j int) bool {
	return s[i].THDetailEx.TradeID > s[j].THDetailEx.TradeID
}
func (s RedisTradeHolderDetailExArray) Swap(i, j int) { s[i], s[j] = s[j], s[i] }

// GetDataEx 从数据库中查询数据
func (r *RedisTradeHolderDetailEx) GetDataEx(userId int, goodsId int) (sData RedisTradeHolderDetailExArray, err error) {
	redisCli := rediscli.GetRedisClient()

	sData = make([]RedisTradeHolderDetailEx, 0)
	key := fmt.Sprintf("TradeHolderDetailEx:%d:*:%d:*", goodsId, userId)
	if ret, err := redisCli.Do("keys", key).Result(); err == nil {
		datas := ret.([]interface{})
		for _, item := range datas {
			itemKey := item.(string)
			if itemValue, err := redisCli.Get(itemKey).Result(); err == nil {
				var data pb.RedisTradeHolderDetailEx
				if err = proto.Unmarshal([]byte(itemValue), &data); err == nil {
					m := RedisTradeHolderDetailEx{}
					m.ParseFromProto(&data)
					sData = append(sData, m)
				}
			}
		}
	}
	// 按 TradeID 倒序排序
	sort.Sort(sort.Reverse(RedisTradeHolderDetailExArray(sData)))

	return sData, nil
}

func (r *RedisTradeHolderDetailEx) ParseFromProto(p *pb.RedisTradeHolderDetailEx) {
	r.FloatPL = p.GetFloatPL()
	r.DepositRate = p.GetDepositRate()
	r.RefundableDeposit = p.GetRefundableDeposit()
	r.GoodsCode = p.GetGoodsCode()
	r.GoodsName = p.GetGoodsName()
	r.GoodsUnitID = p.GetGoodsUnitID()
	r.AgreeUnit = p.GetAgreeUnit()
	r.DecimalPlace = p.GetDecimalPlace()
	r.QuoteMinUnit = p.GetQuoteMinUnit()

	r.THDetailEx = TradeHolderDetailEx{
		TradeID:           p.GetTHDetailEx().GetTradeID(),
		BuyOrSell:         p.GetTHDetailEx().GetBuyOrSell(),
		TradeDate:         p.GetTHDetailEx().GetTradeDate(),
		MarketID:          p.GetTHDetailEx().GetMarketID(),
		GoodsID:           p.GetTHDetailEx().GetGoodsID(),
		UserID:            p.GetTHDetailEx().GetUserID(),
		AccountID:         p.GetTHDetailEx().GetAccountID(),
		MatchUserID:       p.GetTHDetailEx().GetMatchUserID(),
		MatchAccountID:    p.GetTHDetailEx().GetMatchAccountID(),
		OpenQty:           p.GetTHDetailEx().GetOpenQty(),
		TradeAmount:       p.GetTHDetailEx().GetTradeAmount(),
		OpenPrice:         p.GetTHDetailEx().GetOpenPrice(),
		HolderQty:         p.GetTHDetailEx().GetHolderQty(),
		HolderAmount:      p.GetTHDetailEx().GetHolderAmount(),
		HolderPrice:       p.GetTHDetailEx().GetHolderPrice(),
		FreezeQty:         p.GetTHDetailEx().GetFreezeQty(),
		DeliveryQty:       p.GetTHDetailEx().GetDeliveryQty(),
		HoldDays:          p.GetTHDetailEx().GetHoldDays(),
		PayedDeposit:      p.GetTHDetailEx().GetPayedDeposit(),
		RestockDeposit:    p.GetTHDetailEx().GetRestockDeposit(),
		LateFeeDays:       p.GetTHDetailEx().GetLateFeeDays(),
		LateFeeAlgorithm:  p.GetTHDetailEx().GetLateFeeAlgorithm(),
		LateFeeValue:      p.GetTHDetailEx().GetLateFeeValue(),
		CallAteFee:        p.GetTHDetailEx().GetCallAteFee(),
		PromptDepositRate: p.GetTHDetailEx().GetPromptDepositRate(),
		CutDepositRate:    p.GetTHDetailEx().GetCutDepositRate(),
		PromptPrice:       p.GetTHDetailEx().GetPromptPrice(),
		CutPrice:          p.GetTHDetailEx().GetCutPrice(),
		ClosePL:           p.GetTHDetailEx().GetClosePL(),
		FloatPL:           p.GetTHDetailEx().GetFloatPL(),
		DepositRate:       p.GetTHDetailEx().GetDepositRate(),
		RefundableDeposit: p.GetTHDetailEx().GetRefundableDeposit(),
	}

	// 单位
	r.GoodsUnit = mtpcache.GetEnumDicitemName(int32(r.GoodsUnitID))
}