merge:bxsubscribe 协议文件重新生代码

jyBXSubscribe/rpc/type/bxsubscribe/bxsubscribe_grpc.pb.go

@@ -50,6 +50,10 @@ type BxsubscribeClient interface {
 	GetPushSet(ctx context.Context, in *GetPushSetReq, opts ...grpc.CallOption) (*GetPushSetResp, error)
 	//用户推送设置修改
 	SetPushSet(ctx context.Context, in *SetPushSetReq, opts ...grpc.CallOption) (*StatusResp, error)
+	//查看企业员工用户订阅
+	GetStaffSubscribeList(ctx context.Context, in *StaffSubscribeReq, opts ...grpc.CallOption) (*StaffSubscribeListResp, error)
+	//查看企业员工用户订阅详情
+	GetStaffSubscribeDetail(ctx context.Context, in *StaffSubscribeDetailReq, opts ...grpc.CallOption) (*StaffSubscribeDetail, error)
 }
 
 type bxsubscribeClient struct {
@@ -186,6 +190,24 @@ func (c *bxsubscribeClient) SetPushSet(ctx context.Context, in *SetPushSetReq, o
 	return out, nil
 }
 
+func (c *bxsubscribeClient) GetStaffSubscribeList(ctx context.Context, in *StaffSubscribeReq, opts ...grpc.CallOption) (*StaffSubscribeListResp, error) {
+	out := new(StaffSubscribeListResp)
+	err := c.cc.Invoke(ctx, "/bxsubscribe.Bxsubscribe/getStaffSubscribeList", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *bxsubscribeClient) GetStaffSubscribeDetail(ctx context.Context, in *StaffSubscribeDetailReq, opts ...grpc.CallOption) (*StaffSubscribeDetail, error) {
+	out := new(StaffSubscribeDetail)
+	err := c.cc.Invoke(ctx, "/bxsubscribe.Bxsubscribe/getStaffSubscribeDetail", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
 // BxsubscribeServer is the server API for Bxsubscribe service.
 // All implementations must embed UnimplementedBxsubscribeServer
 // for forward compatibility
@@ -218,6 +240,10 @@ type BxsubscribeServer interface {
 	GetPushSet(context.Context, *GetPushSetReq) (*GetPushSetResp, error)
 	//用户推送设置修改
 	SetPushSet(context.Context, *SetPushSetReq) (*StatusResp, error)
+	//查看企业员工用户订阅
+	GetStaffSubscribeList(context.Context, *StaffSubscribeReq) (*StaffSubscribeListResp, error)
+	//查看企业员工用户订阅详情
+	GetStaffSubscribeDetail(context.Context, *StaffSubscribeDetailReq) (*StaffSubscribeDetail, error)
 	mustEmbedUnimplementedBxsubscribeServer()
 }
 
@@ -267,6 +293,12 @@ func (UnimplementedBxsubscribeServer) GetPushSet(context.Context, *GetPushSetReq
 func (UnimplementedBxsubscribeServer) SetPushSet(context.Context, *SetPushSetReq) (*StatusResp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method SetPushSet not implemented")
 }
+func (UnimplementedBxsubscribeServer) GetStaffSubscribeList(context.Context, *StaffSubscribeReq) (*StaffSubscribeListResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetStaffSubscribeList not implemented")
+}
+func (UnimplementedBxsubscribeServer) GetStaffSubscribeDetail(context.Context, *StaffSubscribeDetailReq) (*StaffSubscribeDetail, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetStaffSubscribeDetail not implemented")
+}
 func (UnimplementedBxsubscribeServer) mustEmbedUnimplementedBxsubscribeServer() {}
 
 // UnsafeBxsubscribeServer may be embedded to opt out of forward compatibility for this service.
@@ -532,6 +564,42 @@ func _Bxsubscribe_SetPushSet_Handler(srv interface{}, ctx context.Context, dec f
 	return interceptor(ctx, in, info, handler)
 }
 
+func _Bxsubscribe_GetStaffSubscribeList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(StaffSubscribeReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(BxsubscribeServer).GetStaffSubscribeList(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/bxsubscribe.Bxsubscribe/getStaffSubscribeList",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(BxsubscribeServer).GetStaffSubscribeList(ctx, req.(*StaffSubscribeReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Bxsubscribe_GetStaffSubscribeDetail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(StaffSubscribeDetailReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(BxsubscribeServer).GetStaffSubscribeDetail(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/bxsubscribe.Bxsubscribe/getStaffSubscribeDetail",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(BxsubscribeServer).GetStaffSubscribeDetail(ctx, req.(*StaffSubscribeDetailReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
 // Bxsubscribe_ServiceDesc is the grpc.ServiceDesc for Bxsubscribe service.
 // It's only intended for direct use with grpc.RegisterService,
 // and not to be introspected or modified (even as a copy)
@@ -595,6 +663,14 @@ var Bxsubscribe_ServiceDesc = grpc.ServiceDesc{
 			MethodName: "setPushSet",
 			Handler:    _Bxsubscribe_SetPushSet_Handler,
 		},
+		{
+			MethodName: "getStaffSubscribeList",
+			Handler:    _Bxsubscribe_GetStaffSubscribeList_Handler,
+		},
+		{
+			MethodName: "getStaffSubscribeDetail",
+			Handler:    _Bxsubscribe_GetStaffSubscribeDetail_Handler,
+		},
 	},
 	Streams:  []grpc.StreamDesc{},
 	Metadata: "bxsubscribe.proto",