// Code generated by protoc-gen-go-grpc. DO NOT EDIT. 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 // 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) } 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, "/api.wx.Wx/CronSignInUser", 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, "/api.wx.Wx/CronSendUnreadTemplate", 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, "/api.wx.Wx/SendNewMessageUnreadReminder", 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, "/api.wx.Wx/SendNewVisitorTemplateReminder", 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, "/api.wx.Wx/ReduceUserUnread", 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, "/api.wx.Wx/GetUserMsgByKey", 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, "/api.wx.Wx/WxConf", 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, "/api.wx.Wx/UploadMaterialVoice", 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, "/api.wx.Wx/CronDeleteOldUserSelect", 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, "/api.wx.Wx/GetAccessToken", 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, "/api.wx.Wx/SendNewVisitorReminder", 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, "/api.wx.Wx/SendAIReply", 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, "/api.wx.Wx/GetWxGzhQrcode", 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) 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) 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: "/api.wx.Wx/CronSignInUser", } 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: "/api.wx.Wx/CronSendUnreadTemplate", } 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: "/api.wx.Wx/SendNewMessageUnreadReminder", } 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: "/api.wx.Wx/SendNewVisitorTemplateReminder", } 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: "/api.wx.Wx/ReduceUserUnread", } 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: "/api.wx.Wx/GetUserMsgByKey", } 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: "/api.wx.Wx/WxConf", } 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: "/api.wx.Wx/UploadMaterialVoice", } 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: "/api.wx.Wx/CronDeleteOldUserSelect", } 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: "/api.wx.Wx/GetAccessToken", } 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: "/api.wx.Wx/SendNewVisitorReminder", } 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: "/api.wx.Wx/SendAIReply", } 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: "/api.wx.Wx/GetWxGzhQrcode", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(WxServer).GetWxGzhQrcode(ctx, req.(*GetWxGzhQrcodeRequest)) } 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, }, }, Streams: []grpc.StreamDesc{}, Metadata: "wx.proto", }