// Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.3.0 // - protoc v4.22.3 // source: wx.proto package wx import ( context "context" account "git.ikuban.com/server/pw-protobuf/api/account" common "git.ikuban.com/server/pw-protobuf/api/common" grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" emptypb "google.golang.org/protobuf/types/known/emptypb" ) // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 const ( Wx_CronSignInUser_FullMethodName = "/api.wx.Wx/CronSignInUser" Wx_CronSendUnreadTemplate_FullMethodName = "/api.wx.Wx/CronSendUnreadTemplate" Wx_SendNewMessageUnreadReminder_FullMethodName = "/api.wx.Wx/SendNewMessageUnreadReminder" Wx_SendNewVisitorTemplateReminder_FullMethodName = "/api.wx.Wx/SendNewVisitorTemplateReminder" Wx_ReduceUserUnread_FullMethodName = "/api.wx.Wx/ReduceUserUnread" Wx_GetUserMsgByKey_FullMethodName = "/api.wx.Wx/GetUserMsgByKey" Wx_WxConf_FullMethodName = "/api.wx.Wx/WxConf" Wx_UploadMaterialVoice_FullMethodName = "/api.wx.Wx/UploadMaterialVoice" Wx_CronDeleteOldUserSelect_FullMethodName = "/api.wx.Wx/CronDeleteOldUserSelect" Wx_GetAccessToken_FullMethodName = "/api.wx.Wx/GetAccessToken" Wx_SendNewVisitorReminder_FullMethodName = "/api.wx.Wx/SendNewVisitorReminder" Wx_SendAIReply_FullMethodName = "/api.wx.Wx/SendAIReply" Wx_GetWxGzhQrcode_FullMethodName = "/api.wx.Wx/GetWxGzhQrcode" Wx_SendMiniProgramShareVideoLinkFail_FullMethodName = "/api.wx.Wx/sendMiniProgramShareVideoLinkFail" Wx_SendMiniProgramSuccessInviteFriend_FullMethodName = "/api.wx.Wx/sendMiniProgramSuccessInviteFriend" Wx_SendMiniProgramUpOfficialVersion_FullMethodName = "/api.wx.Wx/sendMiniProgramUpOfficialVersion" ) // WxClient is the client API for Wx service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. type WxClient interface { // 定时发送签到提醒 CronSignInUser(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) // 定时发送未读消息提醒 CronSendUnreadTemplate(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) // 未读发送模板消息 SendNewMessageUnreadReminder(ctx context.Context, in *SendNewMessageUnreadReminderRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // 好友访问提醒 SendNewVisitorTemplateReminder(ctx context.Context, in *common.PersonIDParam, opts ...grpc.CallOption) (*emptypb.Empty, error) // 移除用户已读 ReduceUserUnread(ctx context.Context, in *ReduceUserUnreadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // 获取key对应的参数 GetUserMsgByKey(ctx context.Context, in *GetUserMsgByKeyRequest, opts ...grpc.CallOption) (*GetUserMsgByKeyReply, error) // 微信SDK初始化 WxConf(ctx context.Context, in *common.WxConfReq, opts ...grpc.CallOption) (*common.WxConfResponse, error) // 通过微信下载语音并上传到七牛 UploadMaterialVoice(ctx context.Context, in *account.MediaID, opts ...grpc.CallOption) (*account.MaterialLink, error) // 定时删除过期选择 CronDeleteOldUserSelect(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) GetAccessToken(ctx context.Context, in *GetAccessTokenRequest, opts ...grpc.CallOption) (*GetAccessTokenReply, error) SendNewVisitorReminder(ctx context.Context, in *OpenIDRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) SendAIReply(ctx context.Context, in *SendAIReplyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) GetWxGzhQrcode(ctx context.Context, in *GetWxGzhQrcodeRequest, opts ...grpc.CallOption) (*GetWxGzhQrcodeReply, error) SendMiniProgramShareVideoLinkFail(ctx context.Context, in *SendMiniProgramShareVideoLinkFailRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) SendMiniProgramSuccessInviteFriend(ctx context.Context, in *SendMiniProgramSuccessInviteFriendRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) SendMiniProgramUpOfficialVersion(ctx context.Context, in *common.PersonIDParam, opts ...grpc.CallOption) (*emptypb.Empty, error) } type wxClient struct { cc grpc.ClientConnInterface } func NewWxClient(cc grpc.ClientConnInterface) WxClient { return &wxClient{cc} } func (c *wxClient) CronSignInUser(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Wx_CronSignInUser_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *wxClient) CronSendUnreadTemplate(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Wx_CronSendUnreadTemplate_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *wxClient) SendNewMessageUnreadReminder(ctx context.Context, in *SendNewMessageUnreadReminderRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Wx_SendNewMessageUnreadReminder_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *wxClient) SendNewVisitorTemplateReminder(ctx context.Context, in *common.PersonIDParam, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Wx_SendNewVisitorTemplateReminder_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *wxClient) ReduceUserUnread(ctx context.Context, in *ReduceUserUnreadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Wx_ReduceUserUnread_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *wxClient) GetUserMsgByKey(ctx context.Context, in *GetUserMsgByKeyRequest, opts ...grpc.CallOption) (*GetUserMsgByKeyReply, error) { out := new(GetUserMsgByKeyReply) err := c.cc.Invoke(ctx, Wx_GetUserMsgByKey_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *wxClient) WxConf(ctx context.Context, in *common.WxConfReq, opts ...grpc.CallOption) (*common.WxConfResponse, error) { out := new(common.WxConfResponse) err := c.cc.Invoke(ctx, Wx_WxConf_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *wxClient) UploadMaterialVoice(ctx context.Context, in *account.MediaID, opts ...grpc.CallOption) (*account.MaterialLink, error) { out := new(account.MaterialLink) err := c.cc.Invoke(ctx, Wx_UploadMaterialVoice_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *wxClient) CronDeleteOldUserSelect(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Wx_CronDeleteOldUserSelect_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *wxClient) GetAccessToken(ctx context.Context, in *GetAccessTokenRequest, opts ...grpc.CallOption) (*GetAccessTokenReply, error) { out := new(GetAccessTokenReply) err := c.cc.Invoke(ctx, Wx_GetAccessToken_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *wxClient) SendNewVisitorReminder(ctx context.Context, in *OpenIDRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Wx_SendNewVisitorReminder_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *wxClient) SendAIReply(ctx context.Context, in *SendAIReplyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Wx_SendAIReply_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *wxClient) GetWxGzhQrcode(ctx context.Context, in *GetWxGzhQrcodeRequest, opts ...grpc.CallOption) (*GetWxGzhQrcodeReply, error) { out := new(GetWxGzhQrcodeReply) err := c.cc.Invoke(ctx, Wx_GetWxGzhQrcode_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *wxClient) SendMiniProgramShareVideoLinkFail(ctx context.Context, in *SendMiniProgramShareVideoLinkFailRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Wx_SendMiniProgramShareVideoLinkFail_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *wxClient) SendMiniProgramSuccessInviteFriend(ctx context.Context, in *SendMiniProgramSuccessInviteFriendRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Wx_SendMiniProgramSuccessInviteFriend_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *wxClient) SendMiniProgramUpOfficialVersion(ctx context.Context, in *common.PersonIDParam, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Wx_SendMiniProgramUpOfficialVersion_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } // WxServer is the server API for Wx service. // All implementations must embed UnimplementedWxServer // for forward compatibility type WxServer interface { // 定时发送签到提醒 CronSignInUser(context.Context, *emptypb.Empty) (*emptypb.Empty, error) // 定时发送未读消息提醒 CronSendUnreadTemplate(context.Context, *emptypb.Empty) (*emptypb.Empty, error) // 未读发送模板消息 SendNewMessageUnreadReminder(context.Context, *SendNewMessageUnreadReminderRequest) (*emptypb.Empty, error) // 好友访问提醒 SendNewVisitorTemplateReminder(context.Context, *common.PersonIDParam) (*emptypb.Empty, error) // 移除用户已读 ReduceUserUnread(context.Context, *ReduceUserUnreadRequest) (*emptypb.Empty, error) // 获取key对应的参数 GetUserMsgByKey(context.Context, *GetUserMsgByKeyRequest) (*GetUserMsgByKeyReply, error) // 微信SDK初始化 WxConf(context.Context, *common.WxConfReq) (*common.WxConfResponse, error) // 通过微信下载语音并上传到七牛 UploadMaterialVoice(context.Context, *account.MediaID) (*account.MaterialLink, error) // 定时删除过期选择 CronDeleteOldUserSelect(context.Context, *emptypb.Empty) (*emptypb.Empty, error) GetAccessToken(context.Context, *GetAccessTokenRequest) (*GetAccessTokenReply, error) SendNewVisitorReminder(context.Context, *OpenIDRequest) (*emptypb.Empty, error) SendAIReply(context.Context, *SendAIReplyRequest) (*emptypb.Empty, error) GetWxGzhQrcode(context.Context, *GetWxGzhQrcodeRequest) (*GetWxGzhQrcodeReply, error) SendMiniProgramShareVideoLinkFail(context.Context, *SendMiniProgramShareVideoLinkFailRequest) (*emptypb.Empty, error) SendMiniProgramSuccessInviteFriend(context.Context, *SendMiniProgramSuccessInviteFriendRequest) (*emptypb.Empty, error) SendMiniProgramUpOfficialVersion(context.Context, *common.PersonIDParam) (*emptypb.Empty, error) mustEmbedUnimplementedWxServer() } // UnimplementedWxServer must be embedded to have forward compatible implementations. type UnimplementedWxServer struct { } func (UnimplementedWxServer) CronSignInUser(context.Context, *emptypb.Empty) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method CronSignInUser not implemented") } func (UnimplementedWxServer) CronSendUnreadTemplate(context.Context, *emptypb.Empty) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method CronSendUnreadTemplate not implemented") } func (UnimplementedWxServer) SendNewMessageUnreadReminder(context.Context, *SendNewMessageUnreadReminderRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method SendNewMessageUnreadReminder not implemented") } func (UnimplementedWxServer) SendNewVisitorTemplateReminder(context.Context, *common.PersonIDParam) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method SendNewVisitorTemplateReminder not implemented") } func (UnimplementedWxServer) ReduceUserUnread(context.Context, *ReduceUserUnreadRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method ReduceUserUnread not implemented") } func (UnimplementedWxServer) GetUserMsgByKey(context.Context, *GetUserMsgByKeyRequest) (*GetUserMsgByKeyReply, error) { return nil, status.Errorf(codes.Unimplemented, "method GetUserMsgByKey not implemented") } func (UnimplementedWxServer) WxConf(context.Context, *common.WxConfReq) (*common.WxConfResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method WxConf not implemented") } func (UnimplementedWxServer) UploadMaterialVoice(context.Context, *account.MediaID) (*account.MaterialLink, error) { return nil, status.Errorf(codes.Unimplemented, "method UploadMaterialVoice not implemented") } func (UnimplementedWxServer) CronDeleteOldUserSelect(context.Context, *emptypb.Empty) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method CronDeleteOldUserSelect not implemented") } func (UnimplementedWxServer) GetAccessToken(context.Context, *GetAccessTokenRequest) (*GetAccessTokenReply, error) { return nil, status.Errorf(codes.Unimplemented, "method GetAccessToken not implemented") } func (UnimplementedWxServer) SendNewVisitorReminder(context.Context, *OpenIDRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method SendNewVisitorReminder not implemented") } func (UnimplementedWxServer) SendAIReply(context.Context, *SendAIReplyRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method SendAIReply not implemented") } func (UnimplementedWxServer) GetWxGzhQrcode(context.Context, *GetWxGzhQrcodeRequest) (*GetWxGzhQrcodeReply, error) { return nil, status.Errorf(codes.Unimplemented, "method GetWxGzhQrcode not implemented") } func (UnimplementedWxServer) SendMiniProgramShareVideoLinkFail(context.Context, *SendMiniProgramShareVideoLinkFailRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method SendMiniProgramShareVideoLinkFail not implemented") } func (UnimplementedWxServer) SendMiniProgramSuccessInviteFriend(context.Context, *SendMiniProgramSuccessInviteFriendRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method SendMiniProgramSuccessInviteFriend not implemented") } func (UnimplementedWxServer) SendMiniProgramUpOfficialVersion(context.Context, *common.PersonIDParam) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method SendMiniProgramUpOfficialVersion not implemented") } func (UnimplementedWxServer) mustEmbedUnimplementedWxServer() {} // UnsafeWxServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to WxServer will // result in compilation errors. type UnsafeWxServer interface { mustEmbedUnimplementedWxServer() } func RegisterWxServer(s grpc.ServiceRegistrar, srv WxServer) { s.RegisterService(&Wx_ServiceDesc, srv) } func _Wx_CronSignInUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(emptypb.Empty) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(WxServer).CronSignInUser(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Wx_CronSignInUser_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).CronSignInUser(ctx, req.(*emptypb.Empty)) } return interceptor(ctx, in, info, handler) } func _Wx_CronSendUnreadTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(emptypb.Empty) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(WxServer).CronSendUnreadTemplate(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Wx_CronSendUnreadTemplate_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).CronSendUnreadTemplate(ctx, req.(*emptypb.Empty)) } return interceptor(ctx, in, info, handler) } func _Wx_SendNewMessageUnreadReminder_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SendNewMessageUnreadReminderRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(WxServer).SendNewMessageUnreadReminder(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Wx_SendNewMessageUnreadReminder_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).SendNewMessageUnreadReminder(ctx, req.(*SendNewMessageUnreadReminderRequest)) } return interceptor(ctx, in, info, handler) } func _Wx_SendNewVisitorTemplateReminder_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(common.PersonIDParam) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(WxServer).SendNewVisitorTemplateReminder(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Wx_SendNewVisitorTemplateReminder_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).SendNewVisitorTemplateReminder(ctx, req.(*common.PersonIDParam)) } return interceptor(ctx, in, info, handler) } func _Wx_ReduceUserUnread_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ReduceUserUnreadRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(WxServer).ReduceUserUnread(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Wx_ReduceUserUnread_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).ReduceUserUnread(ctx, req.(*ReduceUserUnreadRequest)) } return interceptor(ctx, in, info, handler) } func _Wx_GetUserMsgByKey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetUserMsgByKeyRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(WxServer).GetUserMsgByKey(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Wx_GetUserMsgByKey_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).GetUserMsgByKey(ctx, req.(*GetUserMsgByKeyRequest)) } return interceptor(ctx, in, info, handler) } func _Wx_WxConf_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(common.WxConfReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(WxServer).WxConf(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Wx_WxConf_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).WxConf(ctx, req.(*common.WxConfReq)) } return interceptor(ctx, in, info, handler) } func _Wx_UploadMaterialVoice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(account.MediaID) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(WxServer).UploadMaterialVoice(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Wx_UploadMaterialVoice_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).UploadMaterialVoice(ctx, req.(*account.MediaID)) } return interceptor(ctx, in, info, handler) } func _Wx_CronDeleteOldUserSelect_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(emptypb.Empty) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(WxServer).CronDeleteOldUserSelect(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Wx_CronDeleteOldUserSelect_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).CronDeleteOldUserSelect(ctx, req.(*emptypb.Empty)) } return interceptor(ctx, in, info, handler) } func _Wx_GetAccessToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetAccessTokenRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(WxServer).GetAccessToken(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Wx_GetAccessToken_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).GetAccessToken(ctx, req.(*GetAccessTokenRequest)) } return interceptor(ctx, in, info, handler) } func _Wx_SendNewVisitorReminder_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(OpenIDRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(WxServer).SendNewVisitorReminder(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Wx_SendNewVisitorReminder_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).SendNewVisitorReminder(ctx, req.(*OpenIDRequest)) } return interceptor(ctx, in, info, handler) } func _Wx_SendAIReply_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SendAIReplyRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(WxServer).SendAIReply(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Wx_SendAIReply_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).SendAIReply(ctx, req.(*SendAIReplyRequest)) } return interceptor(ctx, in, info, handler) } func _Wx_GetWxGzhQrcode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetWxGzhQrcodeRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(WxServer).GetWxGzhQrcode(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Wx_GetWxGzhQrcode_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).GetWxGzhQrcode(ctx, req.(*GetWxGzhQrcodeRequest)) } return interceptor(ctx, in, info, handler) } func _Wx_SendMiniProgramShareVideoLinkFail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SendMiniProgramShareVideoLinkFailRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(WxServer).SendMiniProgramShareVideoLinkFail(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Wx_SendMiniProgramShareVideoLinkFail_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).SendMiniProgramShareVideoLinkFail(ctx, req.(*SendMiniProgramShareVideoLinkFailRequest)) } return interceptor(ctx, in, info, handler) } func _Wx_SendMiniProgramSuccessInviteFriend_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SendMiniProgramSuccessInviteFriendRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(WxServer).SendMiniProgramSuccessInviteFriend(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Wx_SendMiniProgramSuccessInviteFriend_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).SendMiniProgramSuccessInviteFriend(ctx, req.(*SendMiniProgramSuccessInviteFriendRequest)) } return interceptor(ctx, in, info, handler) } func _Wx_SendMiniProgramUpOfficialVersion_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(common.PersonIDParam) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(WxServer).SendMiniProgramUpOfficialVersion(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Wx_SendMiniProgramUpOfficialVersion_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).SendMiniProgramUpOfficialVersion(ctx, req.(*common.PersonIDParam)) } return interceptor(ctx, in, info, handler) } // Wx_ServiceDesc is the grpc.ServiceDesc for Wx service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var Wx_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.wx.Wx", HandlerType: (*WxServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CronSignInUser", Handler: _Wx_CronSignInUser_Handler, }, { MethodName: "CronSendUnreadTemplate", Handler: _Wx_CronSendUnreadTemplate_Handler, }, { MethodName: "SendNewMessageUnreadReminder", Handler: _Wx_SendNewMessageUnreadReminder_Handler, }, { MethodName: "SendNewVisitorTemplateReminder", Handler: _Wx_SendNewVisitorTemplateReminder_Handler, }, { MethodName: "ReduceUserUnread", Handler: _Wx_ReduceUserUnread_Handler, }, { MethodName: "GetUserMsgByKey", Handler: _Wx_GetUserMsgByKey_Handler, }, { MethodName: "WxConf", Handler: _Wx_WxConf_Handler, }, { MethodName: "UploadMaterialVoice", Handler: _Wx_UploadMaterialVoice_Handler, }, { MethodName: "CronDeleteOldUserSelect", Handler: _Wx_CronDeleteOldUserSelect_Handler, }, { MethodName: "GetAccessToken", Handler: _Wx_GetAccessToken_Handler, }, { MethodName: "SendNewVisitorReminder", Handler: _Wx_SendNewVisitorReminder_Handler, }, { MethodName: "SendAIReply", Handler: _Wx_SendAIReply_Handler, }, { MethodName: "GetWxGzhQrcode", Handler: _Wx_GetWxGzhQrcode_Handler, }, { MethodName: "sendMiniProgramShareVideoLinkFail", Handler: _Wx_SendMiniProgramShareVideoLinkFail_Handler, }, { MethodName: "sendMiniProgramSuccessInviteFriend", Handler: _Wx_SendMiniProgramSuccessInviteFriend_Handler, }, { MethodName: "sendMiniProgramUpOfficialVersion", Handler: _Wx_SendMiniProgramUpOfficialVersion_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "wx.proto", }