支持仓单贸易成交通知业务

global/funcode.go

@@ -59,6 +59,7 @@ var (
 
 	THJPurchaseTradeNtf = 1441865 // 铁合金成交通知
 	PurchaseTransferNtf = 1441846 // 铁合金协议转让通知
+	WRTradeDealedNtf    = 131110  // 仓单贸易成交通知
 )
 
 // 通过请求功能码获取对应主题的方法

model/mq/request/ntf.go

@@ -60,6 +60,25 @@ func (r *MQNtfReq) GetProtoBytes() (bytes *[]byte, err error) {
 		} else {
 			bytes = &b
 		}
+	case global.WRTradeDealedNtf:
+		m := pb.WRTradeDealedNtf{}
+		if err = r.reflect(r.Data, &m); err != nil {
+			return
+		}
+		if m.Header != nil {
+			m.Header.RequestID = new(uint32)
+			*m.Header.RequestID = 0
+		} else {
+			err = errors.New("请求信息序列化失败")
+			return
+		}
+		if b, e := proto.Marshal(&m); e != nil {
+			global.M2A_LOG.Error(e.Error(), zap.Error(e))
+			err = errors.New("请求信息序列化失败")
+			return
+		} else {
+			bytes = &b
+		}
 	}
 
 	return

res/pb/mtp2.proto

@@ -17,6 +17,15 @@ message MessageHead {
 	optional uint64 AccountID2 = 11; // 账号ID-币币交易使用
 }
 
+// 公共通知消息头
+message NotifyHead {
+		optional int32 NtfMode = 1; // 消息通知模式(单播、组播、广播)
+		repeated uint32 ExcludeAcctIDs = 2; // 排除账号集合（首先过滤此集合帐号）
+		repeated uint32 ExchIDs = 3; // 目标交易所集合（若匹配所属交易所，推送）
+		repeated uint32 MemberIDs = 4; // 目标会员集合（若匹配所属会员，推送）
+		repeated uint64 AccountIDs = 5; // 目标账号集合（以上均不匹配时，最后检查此集合）
+}
+
 // 修改账户密码请求
 message ModifyPwdReq {
 	optional MessageHead Header = 1;
@@ -769,4 +778,28 @@ message THJPurchaseTradeNtf {
 message PurchaseTransferNtf {
 	optional MessageHead Header = 1; // 消息头
 		optional uint64 TransferID = 2; // uint64 协议转让ID
+}
+
+// 仓单贸易成交通知
+message WRTradeDealedNtf {
+	optional MessageHead Header = 1; // 消息头
+		optional NotifyHead NtfHeader = 2; // NotifyHead 公共消息头
+		optional uint64 ListingOrderID = 3; // uint64 挂牌委托单号
+		optional uint64 DelistingOrderID = 4; // uint64 摘牌委托单号
+		optional uint64 TradeQty = 5; // uint64 挂牌成交数量
+		optional uint64 ActiveQty = 6; // uint64 挂牌剩余数量
+		optional uint64 RealTradeQty = 7; // uint64 摘牌实际成交数量
+		optional uint64 TradeID = 8; // uint64 成交单ID
+		optional uint64 BuyAccountID = 9; // uint64 买资金账号
+		optional uint64 SellAccountID = 10; // uint64 卖资金账号
+		optional double TradePrice = 11; // double 成交价
+		optional string TradeTime = 12; // string 成交时间
+		optional uint64 WRFactorTypeID = 13; // uint64 仓单要素ID
+		optional uint32 WRTransferUserID = 14; // uint32 仓单受让账户
+		optional double FreezeFirstAmount = 15; // double 冻结首付金额
+		optional double UnFreezeFirstAmount = 16; // double 解冻首付金额
+		optional double RealTradeAmount = 17; // double 实际成交金额
+		optional double PerformanceAmount = 18; // double 履约金额
+		optional uint64 PerformancePlanID = 19; // uint64 履约计划ID
+		optional int64 PerformanceTemplateID = 20; // int64 履约计划模板ID
 }