增加水贝亿爵相关业务接口

global/funcode.go

@@ -108,6 +108,15 @@ var (
 
 	HdWRDealOrderReq = 1441809 // 持仓单摘牌请求
 	HdWRDealOrderRsp = 1441810 // 持仓单摘牌应答
+
+	SupplementDepositReq        = 196731 // 补充定金接口请求
+	SupplementDepositRsp        = 196732 // 补充定金接口响应
+	RefundedDepositReq          = 196733 // 退返定金接口请求
+	RefundedDepositRsp          = 196734 // 退返定金接口响应
+	MarketOrderDeliveryApplyReq = 196739 // 按单做市交收申请接口请求
+	MarketOrderDeliveryApplyRsp = 196740 // 按单做市交收申请接口响应
+	DeliveryClientOperatorReq   = 196743 // 交收终端操作接口请求
+	DeliveryClientOperatorRsp   = 196744 // 交收终端操作接口响应
 )
 
 // 通过请求功能码获取对应主题的方法

initialize/rabbitmq.go

@@ -731,6 +731,58 @@ func (t *MQProc) getRspProtobuf(msg *[]byte) (funcode uint32, sessionId uint32,
 			bytes = &bs
 			serialNumber = p.GetHeader().GetRequestID()
 		}
+	case global.SupplementDepositRsp:
+		var p pb.SupplementDepositRsp
+		if err = proto.Unmarshal(b, &p); err != nil {
+			global.M2A_LOG.Error("总线回复数据反序列化失败", zap.Error(err))
+			return
+		}
+		if bs, e := protojson.Marshal(&p); e != nil {
+			global.M2A_LOG.Error("总线回复数据反序列化失败", zap.Error(err))
+			return
+		} else {
+			bytes = &bs
+			serialNumber = p.GetHeader().GetRequestID()
+		}
+	case global.RefundedDepositRsp:
+		var p pb.RefundedDepositRsp
+		if err = proto.Unmarshal(b, &p); err != nil {
+			global.M2A_LOG.Error("总线回复数据反序列化失败", zap.Error(err))
+			return
+		}
+		if bs, e := protojson.Marshal(&p); e != nil {
+			global.M2A_LOG.Error("总线回复数据反序列化失败", zap.Error(err))
+			return
+		} else {
+			bytes = &bs
+			serialNumber = p.GetHeader().GetRequestID()
+		}
+	case global.MarketOrderDeliveryApplyRsp:
+		var p pb.MarketOrderDeliveryApplyRsp
+		if err = proto.Unmarshal(b, &p); err != nil {
+			global.M2A_LOG.Error("总线回复数据反序列化失败", zap.Error(err))
+			return
+		}
+		if bs, e := protojson.Marshal(&p); e != nil {
+			global.M2A_LOG.Error("总线回复数据反序列化失败", zap.Error(err))
+			return
+		} else {
+			bytes = &bs
+			serialNumber = p.GetHeader().GetRequestID()
+		}
+	case global.DeliveryClientOperatorRsp:
+		var p pb.DeliveryClientOperatorRsp
+		if err = proto.Unmarshal(b, &p); err != nil {
+			global.M2A_LOG.Error("总线回复数据反序列化失败", zap.Error(err))
+			return
+		}
+		if bs, e := protojson.Marshal(&p); e != nil {
+			global.M2A_LOG.Error("总线回复数据反序列化失败", zap.Error(err))
+			return
+		} else {
+			bytes = &bs
+			serialNumber = p.GetHeader().GetRequestID()
+		}
 	}
 
 	return
@@ -900,6 +952,10 @@ func InitFuncodeTopic() {
 		global.MakeUpDepositReq,
 		global.HoldAppendDepositReq,
 		global.OfflineDeliveryReq,
+		global.SupplementDepositReq,
+		global.RefundedDepositReq,
+		global.MarketOrderDeliveryApplyReq,
+		global.DeliveryClientOperatorReq,
 	}
 
 	global.M2A_FuncodeTopic[global.TOPIC_REQ_DELIVERY_TRADE] = []int{

model/mq/request/mq.go

@@ -842,6 +842,78 @@ func (r *MQBodyReq) GetProtoBytes(serialNumber *uint32) (bytes *[]byte, err erro
 		} else {
 			bytes = &b
 		}
+	case global.SupplementDepositReq:
+		m := pb.SupplementDepositReq{}
+		if err = r.reflect(data, &m); err != nil {
+			return
+		}
+		if m.Header != nil {
+			m.Header.RequestID = serialNumber
+		} 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
+		}
+	case global.RefundedDepositReq:
+		m := pb.RefundedDepositReq{}
+		if err = r.reflect(data, &m); err != nil {
+			return
+		}
+		if m.Header != nil {
+			m.Header.RequestID = serialNumber
+		} 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
+		}
+	case global.MarketOrderDeliveryApplyReq:
+		m := pb.MarketOrderDeliveryApplyReq{}
+		if err = r.reflect(data, &m); err != nil {
+			return
+		}
+		if m.Header != nil {
+			m.Header.RequestID = serialNumber
+		} 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
+		}
+	case global.DeliveryClientOperatorReq:
+		m := pb.DeliveryClientOperatorReq{}
+		if err = r.reflect(data, &m); err != nil {
+			return
+		}
+		if m.Header != nil {
+			m.Header.RequestID = serialNumber
+		} 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

@@ -1457,4 +1457,105 @@ message HdWRDealOrderRsp {
 		optional double FreezeAmount = 8; // 冻结货款
 		optional string OrderTime = 9; // 接收委托交易的时间
 		optional string ClientSerialNo = 10; // 客户端流水号
+}
+// 补充定金接口请求
+message SupplementDepositReq {
+	optional MessageHead Header = 1;
+		optional uint64 TradeID = 2; // 成交单号，必填
+		optional uint32 BuyOrSell = 3; // 买卖方向，必填
+		optional uint32 UserID = 4; // 用户ID，必填
+		optional uint64 AccountID = 5; // 交易账号，必填
+		optional double RestockDeposit = 6; // 补充定金，必填
+		optional uint32 MarketID = 7; // 市场ID，必填
+		optional string ClientSerialNo = 8; // 客户端流水号
+		optional uint32 ClientType = 9; // 终端类型
+}
+// 补充定金接口响应
+message SupplementDepositRsp {
+	optional MessageHead Header = 1; // 消息头
+	optional int32 RetCode = 2; // 返回码
+	optional string RetDesc = 3; // 描述信息
+		optional uint64 TradeID = 4; // 成交单号，必填
+		optional uint32 UserID = 5; // 用户ID，必填
+		optional uint64 AccountID = 6; // 交易账号，必填
+		optional string ClientSerialNo = 7; // 客户端流水号
+}
+// 退返定金接口请求
+message RefundedDepositReq {
+	optional MessageHead Header = 1;
+		optional uint64 TradeID = 2; // 成交单号，必填
+		optional uint32 BuyOrSell = 3; // 买卖方向，必填
+		optional uint32 UserID = 4; // 用户ID，必填
+		optional uint64 AccountID = 5; // 交易账号，必填
+		optional double RestockDeposit = 6; // 补充定金，必填
+		optional uint32 MarketID = 7; // 市场ID，必填
+		optional string ClientSerialNo = 8; // 客户端流水号
+		optional uint32 ClientType = 9; // 终端类型
+}
+// 退返定金接口响应
+message RefundedDepositRsp {
+	optional MessageHead Header = 1; // 消息头
+	optional int32 RetCode = 2; // 返回码
+	optional string RetDesc = 3; // 描述信息
+		optional uint64 TradeID = 4; // 成交单号，必填
+		optional uint32 UserID = 5; // 用户ID，必填
+		optional uint64 AccountID = 6; // 交易账号，必填
+		optional string ClientSerialNo = 7; // 客户端流水号
+}
+// 持仓明细
+message MarketOrderHoldDetails {
+		optional uint64 TradeID = 1; // 成交单号，必填
+		optional uint32 UserID = 2; // 用户ID，必填
+		optional uint64 AccountID = 3; // 交易账号，必填
+		optional string ClientSerialNo = 4; // 客户端流水号
+}
+// 付款凭证
+message PayAttrs {
+		optional string FileName = 1; // 文件名，必填
+		optional string FileAddr = 2; // 文件地址，必填
+}
+// 按单做市交收申请接口请求
+message MarketOrderDeliveryApplyReq {
+	optional MessageHead Header = 1;
+		optional uint32 UserID = 2; // 用户ID，必填
+		optional uint64 AccountID = 3; // 交易账号，必填
+		repeated MarketOrderHoldDetails HoldDetails = 4; // 持仓明细，必填
+		optional string ClientSerialNo = 5; // 客户端流水号
+		optional uint32 ClientType = 6; // 终端类型
+}
+// 按单做市交收申请接口响应
+message MarketOrderDeliveryApplyRsp {
+	optional MessageHead Header = 1; // 消息头
+	optional int32 RetCode = 2; // 返回码
+	optional string RetDesc = 3; // 描述信息
+		optional uint32 UserID = 4; // 用户ID，必填
+		optional uint64 AccountID = 5; // 交易账号，必填
+		optional string ClientSerialNo = 6; // 客户端流水号
+}
+// 交收终端操作接口请求
+message DeliveryClientOperatorReq {
+	optional MessageHead Header = 1;
+		optional uint32 UserID = 2; // 用户ID，必填
+		optional uint64 AccountID = 3; // 交易账号，必填
+		optional uint64 DeliveryOrderID = 4; // 交收单号，必填
+		optional uint32 OperateType = 5; // 操作类型，必填1:客户确认2:客户付款
+		optional uint32 DeliveryPayMode = 6; // 付款方式，必填1:线上支付2:线下支付
+		optional double PayAmount = 7; // 付款金额，必填
+		repeated PayAttrs PayAttr = 8; // 付款凭证，必填
+		optional uint32 OperatorID = 9; // 操作人ID，必填
+		optional uint64 OperatorAccountID = 10; // 操作人账号，必填
+		optional string OperatorName = 11; // 操作人名称，必填
+		optional string Remark = 12; // 操作备注
+		optional string ClientSerialNo = 13; // 客户端流水号
+		optional uint32 ClientType = 14; // 终端类型
+}
+// 交收终端操作接口响应
+message DeliveryClientOperatorRsp {
+	optional MessageHead Header = 1; // 消息头
+	optional int32 RetCode = 2; // 返回码
+	optional string RetDesc = 3; // 描述信息
+		optional uint64 DeliveryOrderID = 4; // 交收单号，必填
+		optional uint32 UserID = 5; // 用户ID，必填
+		optional uint64 AccountID = 6; // 交易账号，必填
+		optional string ClientSerialNo = 7; // 客户端流水号
 }