增加短信验证码请求

global/funcode.go

@@ -24,14 +24,16 @@ var (
 	DelUserReceiptInfoReq   = 1900551 // 删除用户发票信息请求
 	DelUserReceiptInfoRsp   = 1900552 // 删除用户发票信息请求响应
 
-	T2bBankSignReq       = 589825 // 签约请求
-	T2bBankSignRsp       = 589826 // 签约应答
-	T2bBankCancelSignReq = 589827 // 解约请求
-	T2bBankCancelSignRsp = 589828 // 解约应答
-	T2bBankWithdrawReq   = 589837 // 出金请求
-	T2bBankWithdrawRsp   = 589838 // 出金应答
-	T2bBankDepositReq    = 589843 // 入金请求
-	T2bBankDepositRsp    = 589844 // 入金应答
+	T2bBankSignReq            = 589825 // 签约请求
+	T2bBankSignRsp            = 589826 // 签约应答
+	T2bBankCancelSignReq      = 589827 // 解约请求
+	T2bBankCancelSignRsp      = 589828 // 解约应答
+	T2bBankWithdrawReq        = 589837 // 出金请求
+	T2bBankWithdrawRsp        = 589838 // 出金应答
+	T2bBankDepositReq         = 589843 // 入金请求
+	T2bBankDepositRsp         = 589844 // 入金应答
+	T2bSMSVerificationCodeReq = 589853 // 短信验证码请求
+	T2bSMSVerificationCodeRsp = 589854 // 短信验证码应答
 
 	WarehouseApplyReq                   = 1900685 // 仓库申请请求
 	WarehouseApplyRsp                   = 1900686 // 仓库申请应答

initialize/rabbitmq.go

@@ -63,6 +63,7 @@ func (t *MQProc) Process(topic, queuename string, msg *[]byte) {
 				key := fmt.Sprintf("%v_%v_%v", sessionId, funcode, serialNumber)
 				// 银行服务相关的回复流水号是错误的，所以需要特殊处理
 				if int(funcode) == global.T2bBankSignRsp ||
+					int(funcode) == global.T2bSMSVerificationCodeRsp ||
 					int(funcode) == global.T2bBankCancelSignRsp ||
 					int(funcode) == global.T2bBankWithdrawRsp ||
 					int(funcode) == global.T2bBankDepositRsp {
@@ -409,6 +410,19 @@ func (t *MQProc) getRspProtobuf(msg *[]byte) (funcode uint32, sessionId uint32,
 			bytes = &bs
 			serialNumber = p.GetHeader().GetRequestID()
 		}
+	case global.T2bSMSVerificationCodeRsp:
+		var p pb.T2BSMSVerificationCodeRsp
+		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.T2bBankCancelSignRsp: // 解约应答
 		var p pb.T2BBankCancelSignRsp
 		if err = proto.Unmarshal(b, &p); err != nil {
@@ -1073,6 +1087,7 @@ func InitFuncodeTopic() {
 		global.T2bBankCancelSignReq,
 		global.T2bBankWithdrawReq,
 		global.T2bBankDepositReq,
+		global.T2bSMSVerificationCodeReq,
 	}
 	global.M2A_FuncodeTopic[global.TOPIC_REQ_MONEY] = []int{
 		global.AccountFundInfoReq,

model/mq/request/mq.go

@@ -173,6 +173,24 @@ func (r *MQBodyReq) GetProtoBytes(serialNumber *uint32) (bytes *[]byte, err erro
 		} else {
 			bytes = &b
 		}
+	case global.T2bSMSVerificationCodeReq:
+		m := pb.T2BSMSVerificationCodeReq{}
+		if err = r.reflectNoLong(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.T2bBankCancelSignReq:
 		m := pb.T2BBankCancelSignReq{}
 		if err = r.reflect(data, &m); err != nil {

res/pb/mtp2.pb.go

@@ -14545,6 +14545,254 @@ func (x *OfflineDeliveryApplyCancelOrderRsp) GetClientSerialNo() string {
 	return ""
 }
 
+// 短信验证码请求
+type T2BSMSVerificationCodeReq struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Header        *MessageHead `protobuf:"bytes,1,opt,name=Header" json:"Header,omitempty"`
+	ExtOperatorID *uint64      `protobuf:"varint,2,req,name=ExtOperatorID" json:"ExtOperatorID,omitempty"`             // 外部操作流水号
+	CusBankID     *string      `protobuf:"bytes,3,req,name=CusBankID" json:"CusBankID,omitempty"`                      // 托管银行编号
+	ExchId        *string      `protobuf:"bytes,4,opt,name=ExchId" json:"ExchId,omitempty"`                            // 交易所编号
+	TradeDate     *string      `protobuf:"bytes,5,opt,name=TradeDate" json:"TradeDate,omitempty"`                      // 交易日
+	ExchTicket    *string      `protobuf:"bytes,6,opt,name=ExchTicket" json:"ExchTicket,omitempty"`                    // 交易所流水号
+	AccountCode   *string      `protobuf:"bytes,7,req,name=AccountCode" json:"AccountCode,omitempty"`                  // 资金账户
+	BusinessNo    *string      `protobuf:"bytes,8,opt,name=BusinessNo" json:"BusinessNo,omitempty"`                    // 银行业务编号
+	Mobile        *string      `protobuf:"bytes,9,opt,name=Mobile" json:"Mobile,omitempty"`                            // 手机号码
+	ExtendInfo    *string      `protobuf:"bytes,10,opt,name=extend_info,json=extendInfo" json:"extend_info,omitempty"` // 扩展信息（JSON串，参考配置要求进行填充）
+}
+
+func (x *T2BSMSVerificationCodeReq) Reset() {
+	*x = T2BSMSVerificationCodeReq{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_mtp2_proto_msgTypes[127]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *T2BSMSVerificationCodeReq) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*T2BSMSVerificationCodeReq) ProtoMessage() {}
+
+func (x *T2BSMSVerificationCodeReq) ProtoReflect() protoreflect.Message {
+	mi := &file_mtp2_proto_msgTypes[127]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use T2BSMSVerificationCodeReq.ProtoReflect.Descriptor instead.
+func (*T2BSMSVerificationCodeReq) Descriptor() ([]byte, []int) {
+	return file_mtp2_proto_rawDescGZIP(), []int{127}
+}
+
+func (x *T2BSMSVerificationCodeReq) GetHeader() *MessageHead {
+	if x != nil {
+		return x.Header
+	}
+	return nil
+}
+
+func (x *T2BSMSVerificationCodeReq) GetExtOperatorID() uint64 {
+	if x != nil && x.ExtOperatorID != nil {
+		return *x.ExtOperatorID
+	}
+	return 0
+}
+
+func (x *T2BSMSVerificationCodeReq) GetCusBankID() string {
+	if x != nil && x.CusBankID != nil {
+		return *x.CusBankID
+	}
+	return ""
+}
+
+func (x *T2BSMSVerificationCodeReq) GetExchId() string {
+	if x != nil && x.ExchId != nil {
+		return *x.ExchId
+	}
+	return ""
+}
+
+func (x *T2BSMSVerificationCodeReq) GetTradeDate() string {
+	if x != nil && x.TradeDate != nil {
+		return *x.TradeDate
+	}
+	return ""
+}
+
+func (x *T2BSMSVerificationCodeReq) GetExchTicket() string {
+	if x != nil && x.ExchTicket != nil {
+		return *x.ExchTicket
+	}
+	return ""
+}
+
+func (x *T2BSMSVerificationCodeReq) GetAccountCode() string {
+	if x != nil && x.AccountCode != nil {
+		return *x.AccountCode
+	}
+	return ""
+}
+
+func (x *T2BSMSVerificationCodeReq) GetBusinessNo() string {
+	if x != nil && x.BusinessNo != nil {
+		return *x.BusinessNo
+	}
+	return ""
+}
+
+func (x *T2BSMSVerificationCodeReq) GetMobile() string {
+	if x != nil && x.Mobile != nil {
+		return *x.Mobile
+	}
+	return ""
+}
+
+func (x *T2BSMSVerificationCodeReq) GetExtendInfo() string {
+	if x != nil && x.ExtendInfo != nil {
+		return *x.ExtendInfo
+	}
+	return ""
+}
+
+// 短信验证码应答
+type T2BSMSVerificationCodeRsp struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Header        *MessageHead `protobuf:"bytes,1,opt,name=Header" json:"Header,omitempty"`                // 消息头
+	RetCode       *int32       `protobuf:"varint,2,opt,name=RetCode" json:"RetCode,omitempty"`             // 返回码
+	RetDesc       *string      `protobuf:"bytes,3,opt,name=RetDesc" json:"RetDesc,omitempty"`              // 描述信息
+	ExtOperatorID *uint64      `protobuf:"varint,4,opt,name=ExtOperatorID" json:"ExtOperatorID,omitempty"` // 外部操作流水号
+	Status        *int32       `protobuf:"varint,5,opt,name=Status" json:"Status,omitempty"`               // 状态（0成功,其他数值参考银行服务的错误码）
+	ExchTicket    *string      `protobuf:"bytes,6,req,name=ExchTicket" json:"ExchTicket,omitempty"`        // 交易所流水号
+	ExchId        *string      `protobuf:"bytes,7,opt,name=ExchId" json:"ExchId,omitempty"`                // 交易所编号
+	TradeDate     *string      `protobuf:"bytes,8,opt,name=TradeDate" json:"TradeDate,omitempty"`          // 交易日
+	CenterTicket  *string      `protobuf:"bytes,9,opt,name=CenterTicket" json:"CenterTicket,omitempty"`    // 中心流水号
+	CenterErrCode *string      `protobuf:"bytes,10,opt,name=CenterErrCode" json:"CenterErrCode,omitempty"` // 中心返回码
+	CenterErrMsg  *string      `protobuf:"bytes,11,opt,name=CenterErrMsg" json:"CenterErrMsg,omitempty"`   // 中心返回结果说明
+}
+
+func (x *T2BSMSVerificationCodeRsp) Reset() {
+	*x = T2BSMSVerificationCodeRsp{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_mtp2_proto_msgTypes[128]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *T2BSMSVerificationCodeRsp) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*T2BSMSVerificationCodeRsp) ProtoMessage() {}
+
+func (x *T2BSMSVerificationCodeRsp) ProtoReflect() protoreflect.Message {
+	mi := &file_mtp2_proto_msgTypes[128]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use T2BSMSVerificationCodeRsp.ProtoReflect.Descriptor instead.
+func (*T2BSMSVerificationCodeRsp) Descriptor() ([]byte, []int) {
+	return file_mtp2_proto_rawDescGZIP(), []int{128}
+}
+
+func (x *T2BSMSVerificationCodeRsp) GetHeader() *MessageHead {
+	if x != nil {
+		return x.Header
+	}
+	return nil
+}
+
+func (x *T2BSMSVerificationCodeRsp) GetRetCode() int32 {
+	if x != nil && x.RetCode != nil {
+		return *x.RetCode
+	}
+	return 0
+}
+
+func (x *T2BSMSVerificationCodeRsp) GetRetDesc() string {
+	if x != nil && x.RetDesc != nil {
+		return *x.RetDesc
+	}
+	return ""
+}
+
+func (x *T2BSMSVerificationCodeRsp) GetExtOperatorID() uint64 {
+	if x != nil && x.ExtOperatorID != nil {
+		return *x.ExtOperatorID
+	}
+	return 0
+}
+
+func (x *T2BSMSVerificationCodeRsp) GetStatus() int32 {
+	if x != nil && x.Status != nil {
+		return *x.Status
+	}
+	return 0
+}
+
+func (x *T2BSMSVerificationCodeRsp) GetExchTicket() string {
+	if x != nil && x.ExchTicket != nil {
+		return *x.ExchTicket
+	}
+	return ""
+}
+
+func (x *T2BSMSVerificationCodeRsp) GetExchId() string {
+	if x != nil && x.ExchId != nil {
+		return *x.ExchId
+	}
+	return ""
+}
+
+func (x *T2BSMSVerificationCodeRsp) GetTradeDate() string {
+	if x != nil && x.TradeDate != nil {
+		return *x.TradeDate
+	}
+	return ""
+}
+
+func (x *T2BSMSVerificationCodeRsp) GetCenterTicket() string {
+	if x != nil && x.CenterTicket != nil {
+		return *x.CenterTicket
+	}
+	return ""
+}
+
+func (x *T2BSMSVerificationCodeRsp) GetCenterErrCode() string {
+	if x != nil && x.CenterErrCode != nil {
+		return *x.CenterErrCode
+	}
+	return ""
+}
+
+func (x *T2BSMSVerificationCodeRsp) GetCenterErrMsg() string {
+	if x != nil && x.CenterErrMsg != nil {
+		return *x.CenterErrMsg
+	}
+	return ""
+}
+
 var File_mtp2_proto protoreflect.FileDescriptor
 
 var file_mtp2_proto_rawDesc = []byte{
@@ -17215,7 +17463,52 @@ var file_mtp2_proto_rawDesc = []byte{
 	0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x49, 0x44, 0x12, 0x26, 0x0a, 0x0e, 0x43, 0x6c, 0x69,
 	0x65, 0x6e, 0x74, 0x53, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x4e, 0x6f, 0x18, 0x07, 0x20, 0x01, 0x28,
 	0x09, 0x52, 0x0e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x4e,
-	0x6f,
+	0x6f, 0x22, 0xd9, 0x02, 0x0a, 0x19, 0x74, 0x32, 0x62, 0x53, 0x4d, 0x53, 0x56, 0x65, 0x72, 0x69,
+	0x66, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6f, 0x64, 0x65, 0x52, 0x65, 0x71, 0x12,
+	0x27, 0x0a, 0x06, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32,
+	0x0f, 0x2e, 0x70, 0x62, 0x2e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x48, 0x65, 0x61, 0x64,
+	0x52, 0x06, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x24, 0x0a, 0x0d, 0x45, 0x78, 0x74, 0x4f,
+	0x70, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x49, 0x44, 0x18, 0x02, 0x20, 0x02, 0x28, 0x04, 0x52,
+	0x0d, 0x45, 0x78, 0x74, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x49, 0x44, 0x12, 0x1c,
+	0x0a, 0x09, 0x43, 0x75, 0x73, 0x42, 0x61, 0x6e, 0x6b, 0x49, 0x44, 0x18, 0x03, 0x20, 0x02, 0x28,
+	0x09, 0x52, 0x09, 0x43, 0x75, 0x73, 0x42, 0x61, 0x6e, 0x6b, 0x49, 0x44, 0x12, 0x16, 0x0a, 0x06,
+	0x45, 0x78, 0x63, 0x68, 0x49, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x45, 0x78,
+	0x63, 0x68, 0x49, 0x64, 0x12, 0x1c, 0x0a, 0x09, 0x54, 0x72, 0x61, 0x64, 0x65, 0x44, 0x61, 0x74,
+	0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x54, 0x72, 0x61, 0x64, 0x65, 0x44, 0x61,
+	0x74, 0x65, 0x12, 0x1e, 0x0a, 0x0a, 0x45, 0x78, 0x63, 0x68, 0x54, 0x69, 0x63, 0x6b, 0x65, 0x74,
+	0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x45, 0x78, 0x63, 0x68, 0x54, 0x69, 0x63, 0x6b,
+	0x65, 0x74, 0x12, 0x20, 0x0a, 0x0b, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x43, 0x6f, 0x64,
+	0x65, 0x18, 0x07, 0x20, 0x02, 0x28, 0x09, 0x52, 0x0b, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74,
+	0x43, 0x6f, 0x64, 0x65, 0x12, 0x1e, 0x0a, 0x0a, 0x42, 0x75, 0x73, 0x69, 0x6e, 0x65, 0x73, 0x73,
+	0x4e, 0x6f, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x42, 0x75, 0x73, 0x69, 0x6e, 0x65,
+	0x73, 0x73, 0x4e, 0x6f, 0x12, 0x16, 0x0a, 0x06, 0x4d, 0x6f, 0x62, 0x69, 0x6c, 0x65, 0x18, 0x09,
+	0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x4d, 0x6f, 0x62, 0x69, 0x6c, 0x65, 0x12, 0x1f, 0x0a, 0x0b,
+	0x65, 0x78, 0x74, 0x65, 0x6e, 0x64, 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x0a, 0x20, 0x01, 0x28,
+	0x09, 0x52, 0x0a, 0x65, 0x78, 0x74, 0x65, 0x6e, 0x64, 0x49, 0x6e, 0x66, 0x6f, 0x22, 0xfa, 0x02,
+	0x0a, 0x19, 0x74, 0x32, 0x62, 0x53, 0x4d, 0x53, 0x56, 0x65, 0x72, 0x69, 0x66, 0x69, 0x63, 0x61,
+	0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6f, 0x64, 0x65, 0x52, 0x73, 0x70, 0x12, 0x27, 0x0a, 0x06, 0x48,
+	0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x70, 0x62,
+	0x2e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x48, 0x65, 0x61, 0x64, 0x52, 0x06, 0x48, 0x65,
+	0x61, 0x64, 0x65, 0x72, 0x12, 0x18, 0x0a, 0x07, 0x52, 0x65, 0x74, 0x43, 0x6f, 0x64, 0x65, 0x18,
+	0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x07, 0x52, 0x65, 0x74, 0x43, 0x6f, 0x64, 0x65, 0x12, 0x18,
+	0x0a, 0x07, 0x52, 0x65, 0x74, 0x44, 0x65, 0x73, 0x63, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52,
+	0x07, 0x52, 0x65, 0x74, 0x44, 0x65, 0x73, 0x63, 0x12, 0x24, 0x0a, 0x0d, 0x45, 0x78, 0x74, 0x4f,
+	0x70, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x49, 0x44, 0x18, 0x04, 0x20, 0x01, 0x28, 0x04, 0x52,
+	0x0d, 0x45, 0x78, 0x74, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x49, 0x44, 0x12, 0x16,
+	0x0a, 0x06, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x06,
+	0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x1e, 0x0a, 0x0a, 0x45, 0x78, 0x63, 0x68, 0x54, 0x69,
+	0x63, 0x6b, 0x65, 0x74, 0x18, 0x06, 0x20, 0x02, 0x28, 0x09, 0x52, 0x0a, 0x45, 0x78, 0x63, 0x68,
+	0x54, 0x69, 0x63, 0x6b, 0x65, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x45, 0x78, 0x63, 0x68, 0x49, 0x64,
+	0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x45, 0x78, 0x63, 0x68, 0x49, 0x64, 0x12, 0x1c,
+	0x0a, 0x09, 0x54, 0x72, 0x61, 0x64, 0x65, 0x44, 0x61, 0x74, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28,
+	0x09, 0x52, 0x09, 0x54, 0x72, 0x61, 0x64, 0x65, 0x44, 0x61, 0x74, 0x65, 0x12, 0x22, 0x0a, 0x0c,
+	0x43, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x54, 0x69, 0x63, 0x6b, 0x65, 0x74, 0x18, 0x09, 0x20, 0x01,
+	0x28, 0x09, 0x52, 0x0c, 0x43, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x54, 0x69, 0x63, 0x6b, 0x65, 0x74,
+	0x12, 0x24, 0x0a, 0x0d, 0x43, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x45, 0x72, 0x72, 0x43, 0x6f, 0x64,
+	0x65, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x43, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x45,
+	0x72, 0x72, 0x43, 0x6f, 0x64, 0x65, 0x12, 0x22, 0x0a, 0x0c, 0x43, 0x65, 0x6e, 0x74, 0x65, 0x72,
+	0x45, 0x72, 0x72, 0x4d, 0x73, 0x67, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x43, 0x65,
+	0x6e, 0x74, 0x65, 0x72, 0x45, 0x72, 0x72, 0x4d, 0x73, 0x67,
 }
 
 var (
@@ -17230,7 +17523,7 @@ func file_mtp2_proto_rawDescGZIP() []byte {
 	return file_mtp2_proto_rawDescData
 }
 
-var file_mtp2_proto_msgTypes = make([]protoimpl.MessageInfo, 127)
+var file_mtp2_proto_msgTypes = make([]protoimpl.MessageInfo, 129)
 var file_mtp2_proto_goTypes = []interface{}{
 	(*MessageHead)(nil),                         // 0: pb.MessageHead
 	(*NotifyHead)(nil),                          // 1: pb.NotifyHead
@@ -17359,6 +17652,8 @@ var file_mtp2_proto_goTypes = []interface{}{
 	(*OrderCanceledNtf)(nil),                    // 124: pb.OrderCanceledNtf
 	(*OfflineDeliveryApplyCancelOrderReq)(nil),  // 125: pb.OfflineDeliveryApplyCancelOrderReq
 	(*OfflineDeliveryApplyCancelOrderRsp)(nil),  // 126: pb.OfflineDeliveryApplyCancelOrderRsp
+	(*T2BSMSVerificationCodeReq)(nil),           // 127: pb.t2bSMSVerificationCodeReq
+	(*T2BSMSVerificationCodeRsp)(nil),           // 128: pb.t2bSMSVerificationCodeRsp
 }
 var file_mtp2_proto_depIdxs = []int32{
 	0,   // 0: pb.MoneyChangedNtf.Header:type_name -> pb.MessageHead
@@ -17495,11 +17790,13 @@ var file_mtp2_proto_depIdxs = []int32{
 	1,   // 131: pb.OrderCanceledNtf.NtfHeader:type_name -> pb.NotifyHead
 	0,   // 132: pb.OfflineDeliveryApplyCancelOrderReq.Header:type_name -> pb.MessageHead
 	0,   // 133: pb.OfflineDeliveryApplyCancelOrderRsp.Header:type_name -> pb.MessageHead
-	134, // [134:134] is the sub-list for method output_type
-	134, // [134:134] is the sub-list for method input_type
-	134, // [134:134] is the sub-list for extension type_name
-	134, // [134:134] is the sub-list for extension extendee
-	0,   // [0:134] is the sub-list for field type_name
+	0,   // 134: pb.t2bSMSVerificationCodeReq.Header:type_name -> pb.MessageHead
+	0,   // 135: pb.t2bSMSVerificationCodeRsp.Header:type_name -> pb.MessageHead
+	136, // [136:136] is the sub-list for method output_type
+	136, // [136:136] is the sub-list for method input_type
+	136, // [136:136] is the sub-list for extension type_name
+	136, // [136:136] is the sub-list for extension extendee
+	0,   // [0:136] is the sub-list for field type_name
 }
 
 func init() { file_mtp2_proto_init() }
@@ -19032,6 +19329,30 @@ func file_mtp2_proto_init() {
 				return nil
 			}
 		}
+		file_mtp2_proto_msgTypes[127].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*T2BSMSVerificationCodeReq); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_mtp2_proto_msgTypes[128].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*T2BSMSVerificationCodeRsp); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
 	}
 	type x struct{}
 	out := protoimpl.TypeBuilder{
@@ -19039,7 +19360,7 @@ func file_mtp2_proto_init() {
 			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
 			RawDescriptor: file_mtp2_proto_rawDesc,
 			NumEnums:      0,
-			NumMessages:   127,
+			NumMessages:   129,
 			NumExtensions: 0,
 			NumServices:   0,
 		},

res/pb/mtp2.proto

@@ -1652,4 +1652,31 @@ message OfflineDeliveryApplyCancelOrderRsp {
 		optional uint32 UserID = 5; // 用户ID，必填
 		optional uint64 AccountID = 6; // 交易账号，必填
 		optional string ClientSerialNo = 7; // 客户端流水号
+}
+// 短信验证码请求
+message t2bSMSVerificationCodeReq {
+	optional MessageHead Header = 1;
+		required uint64 ExtOperatorID = 2; // 外部操作流水号
+		required string CusBankID = 3; // 托管银行编号
+		optional string ExchId = 4; // 交易所编号
+		optional string TradeDate = 5; // 交易日
+		optional string ExchTicket = 6; // 交易所流水号
+		required string AccountCode = 7; // 资金账户
+		optional string BusinessNo = 8; // 银行业务编号
+		optional string Mobile = 9; // 手机号码
+		optional string extend_info = 10; // 扩展信息（JSON串，参考配置要求进行填充）
+}
+// 短信验证码应答
+message t2bSMSVerificationCodeRsp {
+	optional MessageHead Header = 1; // 消息头
+	optional int32 RetCode = 2; // 返回码
+	optional string RetDesc = 3; // 描述信息
+		optional uint64 ExtOperatorID = 4; // 外部操作流水号
+		optional int32 Status = 5; // 状态（0成功,其他数值参考银行服务的错误码）
+		required string ExchTicket = 6; // 交易所流水号
+		optional string ExchId = 7; // 交易所编号
+		optional string TradeDate = 8; // 交易日
+		optional string CenterTicket = 9; // 中心流水号
+		optional string CenterErrCode = 10; // 中心返回码
+		optional string CenterErrMsg = 11; // 中心返回结果说明
 }

service/mq/mq.go

@@ -51,6 +51,7 @@ func SendMQ(c *gin.Context, req *request.MQBodyReq) (err error) {
 	global.M2A_LOG.Info("创建异步任务", zap.Any("SessionID", t.SessionID), zap.Any("serialNumber", serialNumber))
 	// 银行服务相关的回复流水号是错误的，所以需要特殊处理
 	if int(req.FunCodeReq) == global.T2bBankSignReq ||
+		int(req.FunCodeReq) == global.T2bSMSVerificationCodeReq ||
 		int(req.FunCodeReq) == global.T2bBankCancelSignReq ||
 		int(req.FunCodeReq) == global.T2bBankWithdrawReq ||
 		int(req.FunCodeReq) == global.T2bBankDepositReq {