|
@@ -46,6 +46,8 @@ type StatisticsClient interface {
|
|
|
GetIsLike(ctx context.Context, in *PersonMessage, opts ...grpc.CallOption) (*common.IsLike, error)
|
|
GetIsLike(ctx context.Context, in *PersonMessage, opts ...grpc.CallOption) (*common.IsLike, error)
|
|
|
// 统计订阅消息
|
|
// 统计订阅消息
|
|
|
StatisticsSubscribeMessage(ctx context.Context, in *StatisticsSubscribeMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
|
StatisticsSubscribeMessage(ctx context.Context, in *StatisticsSubscribeMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
|
|
|
|
+ // 统计订阅消息
|
|
|
|
|
+ StatisticsAISubscribeMessage(ctx context.Context, in *StatisticsAISubscribeMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
|
|
// 减少订阅消息
|
|
// 减少订阅消息
|
|
|
ReduceSubscribeMessage(ctx context.Context, in *ReduceSubscribeMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
|
ReduceSubscribeMessage(ctx context.Context, in *ReduceSubscribeMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
|
|
// 获取订阅了签到的人
|
|
// 获取订阅了签到的人
|
|
@@ -179,6 +181,15 @@ func (c *statisticsClient) StatisticsSubscribeMessage(ctx context.Context, in *S
|
|
|
return out, nil
|
|
return out, nil
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+func (c *statisticsClient) StatisticsAISubscribeMessage(ctx context.Context, in *StatisticsAISubscribeMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
|
|
|
|
+ out := new(emptypb.Empty)
|
|
|
|
|
+ err := c.cc.Invoke(ctx, "/api.statistics.Statistics/StatisticsAISubscribeMessage", in, out, opts...)
|
|
|
|
|
+ if err != nil {
|
|
|
|
|
+ return nil, err
|
|
|
|
|
+ }
|
|
|
|
|
+ return out, nil
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
func (c *statisticsClient) ReduceSubscribeMessage(ctx context.Context, in *ReduceSubscribeMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
|
func (c *statisticsClient) ReduceSubscribeMessage(ctx context.Context, in *ReduceSubscribeMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
|
|
out := new(emptypb.Empty)
|
|
out := new(emptypb.Empty)
|
|
|
err := c.cc.Invoke(ctx, "/api.statistics.Statistics/ReduceSubscribeMessage", in, out, opts...)
|
|
err := c.cc.Invoke(ctx, "/api.statistics.Statistics/ReduceSubscribeMessage", in, out, opts...)
|
|
@@ -236,6 +247,8 @@ type StatisticsServer interface {
|
|
|
GetIsLike(context.Context, *PersonMessage) (*common.IsLike, error)
|
|
GetIsLike(context.Context, *PersonMessage) (*common.IsLike, error)
|
|
|
// 统计订阅消息
|
|
// 统计订阅消息
|
|
|
StatisticsSubscribeMessage(context.Context, *StatisticsSubscribeMessageRequest) (*emptypb.Empty, error)
|
|
StatisticsSubscribeMessage(context.Context, *StatisticsSubscribeMessageRequest) (*emptypb.Empty, error)
|
|
|
|
|
+ // 统计订阅消息
|
|
|
|
|
+ StatisticsAISubscribeMessage(context.Context, *StatisticsAISubscribeMessageRequest) (*emptypb.Empty, error)
|
|
|
// 减少订阅消息
|
|
// 减少订阅消息
|
|
|
ReduceSubscribeMessage(context.Context, *ReduceSubscribeMessageRequest) (*emptypb.Empty, error)
|
|
ReduceSubscribeMessage(context.Context, *ReduceSubscribeMessageRequest) (*emptypb.Empty, error)
|
|
|
// 获取订阅了签到的人
|
|
// 获取订阅了签到的人
|
|
@@ -288,6 +301,9 @@ func (UnimplementedStatisticsServer) GetIsLike(context.Context, *PersonMessage)
|
|
|
func (UnimplementedStatisticsServer) StatisticsSubscribeMessage(context.Context, *StatisticsSubscribeMessageRequest) (*emptypb.Empty, error) {
|
|
func (UnimplementedStatisticsServer) StatisticsSubscribeMessage(context.Context, *StatisticsSubscribeMessageRequest) (*emptypb.Empty, error) {
|
|
|
return nil, status.Errorf(codes.Unimplemented, "method StatisticsSubscribeMessage not implemented")
|
|
return nil, status.Errorf(codes.Unimplemented, "method StatisticsSubscribeMessage not implemented")
|
|
|
}
|
|
}
|
|
|
|
|
+func (UnimplementedStatisticsServer) StatisticsAISubscribeMessage(context.Context, *StatisticsAISubscribeMessageRequest) (*emptypb.Empty, error) {
|
|
|
|
|
+ return nil, status.Errorf(codes.Unimplemented, "method StatisticsAISubscribeMessage not implemented")
|
|
|
|
|
+}
|
|
|
func (UnimplementedStatisticsServer) ReduceSubscribeMessage(context.Context, *ReduceSubscribeMessageRequest) (*emptypb.Empty, error) {
|
|
func (UnimplementedStatisticsServer) ReduceSubscribeMessage(context.Context, *ReduceSubscribeMessageRequest) (*emptypb.Empty, error) {
|
|
|
return nil, status.Errorf(codes.Unimplemented, "method ReduceSubscribeMessage not implemented")
|
|
return nil, status.Errorf(codes.Unimplemented, "method ReduceSubscribeMessage not implemented")
|
|
|
}
|
|
}
|
|
@@ -544,6 +560,24 @@ func _Statistics_StatisticsSubscribeMessage_Handler(srv interface{}, ctx context
|
|
|
return interceptor(ctx, in, info, handler)
|
|
return interceptor(ctx, in, info, handler)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+func _Statistics_StatisticsAISubscribeMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
|
|
|
+ in := new(StatisticsAISubscribeMessageRequest)
|
|
|
|
|
+ if err := dec(in); err != nil {
|
|
|
|
|
+ return nil, err
|
|
|
|
|
+ }
|
|
|
|
|
+ if interceptor == nil {
|
|
|
|
|
+ return srv.(StatisticsServer).StatisticsAISubscribeMessage(ctx, in)
|
|
|
|
|
+ }
|
|
|
|
|
+ info := &grpc.UnaryServerInfo{
|
|
|
|
|
+ Server: srv,
|
|
|
|
|
+ FullMethod: "/api.statistics.Statistics/StatisticsAISubscribeMessage",
|
|
|
|
|
+ }
|
|
|
|
|
+ handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
|
|
|
+ return srv.(StatisticsServer).StatisticsAISubscribeMessage(ctx, req.(*StatisticsAISubscribeMessageRequest))
|
|
|
|
|
+ }
|
|
|
|
|
+ return interceptor(ctx, in, info, handler)
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
func _Statistics_ReduceSubscribeMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
func _Statistics_ReduceSubscribeMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
|
in := new(ReduceSubscribeMessageRequest)
|
|
in := new(ReduceSubscribeMessageRequest)
|
|
|
if err := dec(in); err != nil {
|
|
if err := dec(in); err != nil {
|
|
@@ -657,6 +691,10 @@ var Statistics_ServiceDesc = grpc.ServiceDesc{
|
|
|
MethodName: "StatisticsSubscribeMessage",
|
|
MethodName: "StatisticsSubscribeMessage",
|
|
|
Handler: _Statistics_StatisticsSubscribeMessage_Handler,
|
|
Handler: _Statistics_StatisticsSubscribeMessage_Handler,
|
|
|
},
|
|
},
|
|
|
|
|
+ {
|
|
|
|
|
+ MethodName: "StatisticsAISubscribeMessage",
|
|
|
|
|
+ Handler: _Statistics_StatisticsAISubscribeMessage_Handler,
|
|
|
|
|
+ },
|
|
|
{
|
|
{
|
|
|
MethodName: "ReduceSubscribeMessage",
|
|
MethodName: "ReduceSubscribeMessage",
|
|
|
Handler: _Statistics_ReduceSubscribeMessage_Handler,
|
|
Handler: _Statistics_ReduceSubscribeMessage_Handler,
|