wfz vor 2 Jahren
Ursprung
Commit
e0453d33be

+ 67 - 88
api/chat/chat.pb.go

@@ -2504,7 +2504,7 @@ var file_chat_proto_rawDesc = []byte{
 	0x61, 0x62, 0x69, 0x6c, 0x69, 0x74, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0b, 0x6c,
 	0x69, 0x6b, 0x65, 0x61, 0x62, 0x69, 0x6c, 0x69, 0x74, 0x79, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x6f,
 	0x6f, 0x6d, 0x49, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x72, 0x6f, 0x6f, 0x6d,
-	0x49, 0x64, 0x32, 0xd3, 0x1f, 0x0a, 0x04, 0x43, 0x68, 0x61, 0x74, 0x12, 0x69, 0x0a, 0x1e, 0x43,
+	0x49, 0x64, 0x32, 0x92, 0x1e, 0x0a, 0x04, 0x43, 0x68, 0x61, 0x74, 0x12, 0x69, 0x0a, 0x1e, 0x43,
 	0x68, 0x65, 0x63, 0x6b, 0x55, 0x73, 0x65, 0x72, 0x50, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x49,
 	0x73, 0x52, 0x65, 0x6c, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x68, 0x69, 0x70, 0x12, 0x18, 0x2e,
 	0x61, 0x70, 0x69, 0x2e, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x49,
@@ -2745,23 +2745,11 @@ var file_chat_proto_rawDesc = []byte{
 	0x63, 0x68, 0x61, 0x74, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65,
 	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x63, 0x6f,
 	0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65,
-	0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x00, 0x12, 0x40, 0x0a, 0x04, 0x53, 0x65, 0x6e, 0x64, 0x12,
-	0x1e, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x53, 0x65, 0x6e,
-	0x64, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
-	0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75,
-	0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x41, 0x0a, 0x09, 0x47, 0x65, 0x74,
-	0x49, 0x73, 0x52, 0x65, 0x61, 0x64, 0x12, 0x1a, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x63, 0x6f, 0x6d,
-	0x6d, 0x6f, 0x6e, 0x2e, 0x43, 0x68, 0x61, 0x74, 0x49, 0x73, 0x52, 0x65, 0x61, 0x64, 0x49, 0x6e,
-	0x66, 0x6f, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
-	0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x3a, 0x0a, 0x08,
-	0x47, 0x6f, 0x74, 0x6f, 0x52, 0x6f, 0x6f, 0x6d, 0x12, 0x14, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x63,
-	0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x47, 0x6f, 0x54, 0x6f, 0x52, 0x6f, 0x6f, 0x6d, 0x1a, 0x16,
-	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66,
-	0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x42, 0x3d, 0x0a, 0x08, 0x61, 0x70, 0x69, 0x2e,
-	0x63, 0x68, 0x61, 0x74, 0x50, 0x01, 0x5a, 0x2f, 0x67, 0x69, 0x74, 0x2e, 0x69, 0x6b, 0x75, 0x62,
-	0x61, 0x6e, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2f, 0x70, 0x77,
-	0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x68,
-	0x61, 0x74, 0x3b, 0x63, 0x68, 0x61, 0x74, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+	0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x00, 0x42, 0x3d, 0x0a, 0x08, 0x61, 0x70, 0x69, 0x2e, 0x63,
+	0x68, 0x61, 0x74, 0x50, 0x01, 0x5a, 0x2f, 0x67, 0x69, 0x74, 0x2e, 0x69, 0x6b, 0x75, 0x62, 0x61,
+	0x6e, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2f, 0x70, 0x77, 0x2d,
+	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x68, 0x61,
+	0x74, 0x3b, 0x63, 0x68, 0x61, 0x74, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
 }
 
 var (
@@ -2834,23 +2822,20 @@ var file_chat_proto_goTypes = []interface{}{
 	(*common.IDParam)(nil),                             // 53: api.common.IDParam
 	(*common.ManagerFindReportListRequest)(nil),        // 54: api.common.ManagerFindReportListRequest
 	(*common.ManagerFindReportDetailsListRequest)(nil), // 55: api.common.ManagerFindReportDetailsListRequest
-	(*common.SendMessageRequest)(nil),                  // 56: api.common.SendMessageRequest
-	(*common.ChatIsReadInfo)(nil),                      // 57: api.common.ChatIsReadInfo
-	(*common.GoToRoom)(nil),                            // 58: api.common.GoToRoom
-	(*common.RecommendPersonListReply)(nil),            // 59: api.common.RecommendPersonListReply
-	(*common.ChatRecordListReply)(nil),                 // 60: api.common.ChatRecordListReply
-	(*common.ChatRoomMsg)(nil),                         // 61: api.common.ChatRoomMsg
-	(*common.RoomChatMsg)(nil),                         // 62: api.common.RoomChatMsg
-	(*common.ScripID)(nil),                             // 63: api.common.ScripID
-	(*common.ScripReply)(nil),                          // 64: api.common.ScripReply
-	(*common.ScripInfo)(nil),                           // 65: api.common.ScripInfo
-	(*common.ChatRecordInfo)(nil),                      // 66: api.common.ChatRecordInfo
-	(*common.GetMatchingPartnerInfoReply)(nil),         // 67: api.common.GetMatchingPartnerInfoReply
-	(*common.ManagerFindRoomListReply)(nil),            // 68: api.common.ManagerFindRoomListReply
-	(*common.ManagerScripReply)(nil),                   // 69: api.common.ManagerScripReply
-	(*common.ManagerFindReportListReply)(nil),          // 70: api.common.ManagerFindReportListReply
-	(*common.ManagerFindReportDetailsListReply)(nil),   // 71: api.common.ManagerFindReportDetailsListReply
-	(*common.SendMessageReply)(nil),                    // 72: api.common.SendMessageReply
+	(*common.RecommendPersonListReply)(nil),            // 56: api.common.RecommendPersonListReply
+	(*common.ChatRecordListReply)(nil),                 // 57: api.common.ChatRecordListReply
+	(*common.ChatRoomMsg)(nil),                         // 58: api.common.ChatRoomMsg
+	(*common.RoomChatMsg)(nil),                         // 59: api.common.RoomChatMsg
+	(*common.ScripID)(nil),                             // 60: api.common.ScripID
+	(*common.ScripReply)(nil),                          // 61: api.common.ScripReply
+	(*common.ScripInfo)(nil),                           // 62: api.common.ScripInfo
+	(*common.ChatRecordInfo)(nil),                      // 63: api.common.ChatRecordInfo
+	(*common.GetMatchingPartnerInfoReply)(nil),         // 64: api.common.GetMatchingPartnerInfoReply
+	(*common.ManagerFindRoomListReply)(nil),            // 65: api.common.ManagerFindRoomListReply
+	(*common.ManagerScripReply)(nil),                   // 66: api.common.ManagerScripReply
+	(*common.ManagerFindReportListReply)(nil),          // 67: api.common.ManagerFindReportListReply
+	(*common.ManagerFindReportDetailsListReply)(nil),   // 68: api.common.ManagerFindReportDetailsListReply
+	(*common.SendMessageReply)(nil),                    // 69: api.common.SendMessageReply
 }
 var file_chat_proto_depIdxs = []int32{
 	33, // 0: api.chat.SendMessageRequest.message:type_name -> api.common.Message
@@ -2901,59 +2886,53 @@ var file_chat_proto_depIdxs = []int32{
 	55, // 45: api.chat.Chat.ManagerFindReportDetailsList:input_type -> api.common.ManagerFindReportDetailsListRequest
 	47, // 46: api.chat.Chat.DeleteScripByPersonID:input_type -> api.common.PersonIDParam
 	0,  // 47: api.chat.Chat.SendMessage:input_type -> api.chat.SendMessageRequest
-	56, // 48: api.chat.Chat.Send:input_type -> api.common.SendMessageRequest
-	57, // 49: api.chat.Chat.GetIsRead:input_type -> api.common.ChatIsReadInfo
-	58, // 50: api.chat.Chat.GotoRoom:input_type -> api.common.GoToRoom
-	25, // 51: api.chat.Chat.CheckUserPartnerIsRelationship:output_type -> api.chat.CheckUserPartnerIsRelationshipReply
-	26, // 52: api.chat.Chat.CreateChatRoom:output_type -> api.chat.RoomReply
-	59, // 53: api.chat.Chat.FindOnlinePersonList:output_type -> api.common.RecommendPersonListReply
-	59, // 54: api.chat.Chat.FindRecommendPersonList:output_type -> api.common.RecommendPersonListReply
-	19, // 55: api.chat.Chat.PartnerFindRoomList:output_type -> api.chat.PartnerFindRoomListReply
-	16, // 56: api.chat.Chat.UserFindRoomList:output_type -> api.chat.UserFindRoomListReply
-	24, // 57: api.chat.Chat.Receive:output_type -> api.chat.ReceiveReply
-	60, // 58: api.chat.Chat.FindChatRecordList:output_type -> api.common.ChatRecordListReply
-	61, // 59: api.chat.Chat.FindChatRoomMsg:output_type -> api.common.ChatRoomMsg
-	46, // 60: api.chat.Chat.SetBlackChat:output_type -> google.protobuf.Empty
-	46, // 61: api.chat.Chat.DeleteChat:output_type -> google.protobuf.Empty
-	46, // 62: api.chat.Chat.Report:output_type -> google.protobuf.Empty
-	62, // 63: api.chat.Chat.FindRoomCardMsg:output_type -> api.common.RoomChatMsg
-	63, // 64: api.chat.Chat.CreateScrip:output_type -> api.common.ScripID
-	46, // 65: api.chat.Chat.DeleteScrip:output_type -> google.protobuf.Empty
-	64, // 66: api.chat.Chat.FindMyScrip:output_type -> api.common.ScripReply
-	64, // 67: api.chat.Chat.FindOtherScrip:output_type -> api.common.ScripReply
-	64, // 68: api.chat.Chat.FindRecommendScrip:output_type -> api.common.ScripReply
-	46, // 69: api.chat.Chat.PersonLookScrip:output_type -> google.protobuf.Empty
-	65, // 70: api.chat.Chat.PersonClickLookBack:output_type -> api.common.ScripInfo
-	66, // 71: api.chat.Chat.PersonReplyScrip:output_type -> api.common.ChatRecordInfo
-	29, // 72: api.chat.Chat.GetWindowInfo:output_type -> api.chat.WindowInfo
-	8,  // 73: api.chat.Chat.GetRandomMatching:output_type -> api.chat.GetRandomMatchingReply
-	67, // 74: api.chat.Chat.GetMatchingPartnerInfo:output_type -> api.common.GetMatchingPartnerInfoReply
-	67, // 75: api.chat.Chat.AccurateMatchingUserInfo:output_type -> api.common.GetMatchingPartnerInfoReply
-	46, // 76: api.chat.Chat.PartnerCollect:output_type -> google.protobuf.Empty
-	46, // 77: api.chat.Chat.PartnerDeleteCollect:output_type -> google.protobuf.Empty
-	60, // 78: api.chat.Chat.FindChatCollectList:output_type -> api.common.ChatRecordListReply
-	46, // 79: api.chat.Chat.UserUnlockVoice:output_type -> google.protobuf.Empty
-	46, // 80: api.chat.Chat.UserUnlockPicture:output_type -> google.protobuf.Empty
-	4,  // 81: api.chat.Chat.GetRoomProfit:output_type -> api.chat.GetRoomProfitReply
-	1,  // 82: api.chat.Chat.GetOnlinePersonNum:output_type -> api.chat.GetOnlinePersonNumReply
-	10, // 83: api.chat.Chat.FindUserAllUnreadNum:output_type -> api.chat.UnreadNumReply
-	17, // 84: api.chat.Chat.GetUserRoomByPerson:output_type -> api.chat.UserRoomInfo
-	18, // 85: api.chat.Chat.GetSuperLoveByPerson:output_type -> api.chat.UserSuperLoveInfo
-	68, // 86: api.chat.Chat.ManagerFindRoomList:output_type -> api.common.ManagerFindRoomListReply
-	60, // 87: api.chat.Chat.ManagerFindChatRecordList:output_type -> api.common.ChatRecordListReply
-	69, // 88: api.chat.Chat.ManagerFindScripList:output_type -> api.common.ManagerScripReply
-	46, // 89: api.chat.Chat.ManagerUpdateScripText:output_type -> google.protobuf.Empty
-	46, // 90: api.chat.Chat.ManagerUpdateScripPicture:output_type -> google.protobuf.Empty
-	46, // 91: api.chat.Chat.ManagerDeleteScrip:output_type -> google.protobuf.Empty
-	70, // 92: api.chat.Chat.ManagerFindReportList:output_type -> api.common.ManagerFindReportListReply
-	71, // 93: api.chat.Chat.ManagerFindReportDetailsList:output_type -> api.common.ManagerFindReportDetailsListReply
-	46, // 94: api.chat.Chat.DeleteScripByPersonID:output_type -> google.protobuf.Empty
-	72, // 95: api.chat.Chat.SendMessage:output_type -> api.common.SendMessageReply
-	46, // 96: api.chat.Chat.Send:output_type -> google.protobuf.Empty
-	46, // 97: api.chat.Chat.GetIsRead:output_type -> google.protobuf.Empty
-	46, // 98: api.chat.Chat.GotoRoom:output_type -> google.protobuf.Empty
-	51, // [51:99] is the sub-list for method output_type
-	3,  // [3:51] is the sub-list for method input_type
+	25, // 48: api.chat.Chat.CheckUserPartnerIsRelationship:output_type -> api.chat.CheckUserPartnerIsRelationshipReply
+	26, // 49: api.chat.Chat.CreateChatRoom:output_type -> api.chat.RoomReply
+	56, // 50: api.chat.Chat.FindOnlinePersonList:output_type -> api.common.RecommendPersonListReply
+	56, // 51: api.chat.Chat.FindRecommendPersonList:output_type -> api.common.RecommendPersonListReply
+	19, // 52: api.chat.Chat.PartnerFindRoomList:output_type -> api.chat.PartnerFindRoomListReply
+	16, // 53: api.chat.Chat.UserFindRoomList:output_type -> api.chat.UserFindRoomListReply
+	24, // 54: api.chat.Chat.Receive:output_type -> api.chat.ReceiveReply
+	57, // 55: api.chat.Chat.FindChatRecordList:output_type -> api.common.ChatRecordListReply
+	58, // 56: api.chat.Chat.FindChatRoomMsg:output_type -> api.common.ChatRoomMsg
+	46, // 57: api.chat.Chat.SetBlackChat:output_type -> google.protobuf.Empty
+	46, // 58: api.chat.Chat.DeleteChat:output_type -> google.protobuf.Empty
+	46, // 59: api.chat.Chat.Report:output_type -> google.protobuf.Empty
+	59, // 60: api.chat.Chat.FindRoomCardMsg:output_type -> api.common.RoomChatMsg
+	60, // 61: api.chat.Chat.CreateScrip:output_type -> api.common.ScripID
+	46, // 62: api.chat.Chat.DeleteScrip:output_type -> google.protobuf.Empty
+	61, // 63: api.chat.Chat.FindMyScrip:output_type -> api.common.ScripReply
+	61, // 64: api.chat.Chat.FindOtherScrip:output_type -> api.common.ScripReply
+	61, // 65: api.chat.Chat.FindRecommendScrip:output_type -> api.common.ScripReply
+	46, // 66: api.chat.Chat.PersonLookScrip:output_type -> google.protobuf.Empty
+	62, // 67: api.chat.Chat.PersonClickLookBack:output_type -> api.common.ScripInfo
+	63, // 68: api.chat.Chat.PersonReplyScrip:output_type -> api.common.ChatRecordInfo
+	29, // 69: api.chat.Chat.GetWindowInfo:output_type -> api.chat.WindowInfo
+	8,  // 70: api.chat.Chat.GetRandomMatching:output_type -> api.chat.GetRandomMatchingReply
+	64, // 71: api.chat.Chat.GetMatchingPartnerInfo:output_type -> api.common.GetMatchingPartnerInfoReply
+	64, // 72: api.chat.Chat.AccurateMatchingUserInfo:output_type -> api.common.GetMatchingPartnerInfoReply
+	46, // 73: api.chat.Chat.PartnerCollect:output_type -> google.protobuf.Empty
+	46, // 74: api.chat.Chat.PartnerDeleteCollect:output_type -> google.protobuf.Empty
+	57, // 75: api.chat.Chat.FindChatCollectList:output_type -> api.common.ChatRecordListReply
+	46, // 76: api.chat.Chat.UserUnlockVoice:output_type -> google.protobuf.Empty
+	46, // 77: api.chat.Chat.UserUnlockPicture:output_type -> google.protobuf.Empty
+	4,  // 78: api.chat.Chat.GetRoomProfit:output_type -> api.chat.GetRoomProfitReply
+	1,  // 79: api.chat.Chat.GetOnlinePersonNum:output_type -> api.chat.GetOnlinePersonNumReply
+	10, // 80: api.chat.Chat.FindUserAllUnreadNum:output_type -> api.chat.UnreadNumReply
+	17, // 81: api.chat.Chat.GetUserRoomByPerson:output_type -> api.chat.UserRoomInfo
+	18, // 82: api.chat.Chat.GetSuperLoveByPerson:output_type -> api.chat.UserSuperLoveInfo
+	65, // 83: api.chat.Chat.ManagerFindRoomList:output_type -> api.common.ManagerFindRoomListReply
+	57, // 84: api.chat.Chat.ManagerFindChatRecordList:output_type -> api.common.ChatRecordListReply
+	66, // 85: api.chat.Chat.ManagerFindScripList:output_type -> api.common.ManagerScripReply
+	46, // 86: api.chat.Chat.ManagerUpdateScripText:output_type -> google.protobuf.Empty
+	46, // 87: api.chat.Chat.ManagerUpdateScripPicture:output_type -> google.protobuf.Empty
+	46, // 88: api.chat.Chat.ManagerDeleteScrip:output_type -> google.protobuf.Empty
+	67, // 89: api.chat.Chat.ManagerFindReportList:output_type -> api.common.ManagerFindReportListReply
+	68, // 90: api.chat.Chat.ManagerFindReportDetailsList:output_type -> api.common.ManagerFindReportDetailsListReply
+	46, // 91: api.chat.Chat.DeleteScripByPersonID:output_type -> google.protobuf.Empty
+	69, // 92: api.chat.Chat.SendMessage:output_type -> api.common.SendMessageReply
+	48, // [48:93] is the sub-list for method output_type
+	3,  // [3:48] is the sub-list for method input_type
 	3,  // [3:3] is the sub-list for extension type_name
 	3,  // [3:3] is the sub-list for extension extendee
 	0,  // [0:3] is the sub-list for field type_name

+ 0 - 6
api/chat/chat.proto

@@ -102,12 +102,6 @@ service Chat {
   rpc DeleteScripByPersonID (common.PersonIDParam) returns (google.protobuf.Empty){};
   // 发送消息
   rpc SendMessage (SendMessageRequest) returns (common.SendMessageReply){};
-  // 发送消息 new
-  rpc Send (common.SendMessageRequest) returns (google.protobuf.Empty){};
-  // 获取到后将对应数据变为已读
-  rpc GetIsRead (common.ChatIsReadInfo) returns (google.protobuf.Empty){};
-  // 用户进入房间
-  rpc GotoRoom (common.GoToRoom) returns (google.protobuf.Empty){};
 }
 
 message SendMessageRequest{

+ 0 - 114
api/chat/chat_grpc.pb.go

@@ -110,12 +110,6 @@ type ChatClient interface {
 	DeleteScripByPersonID(ctx context.Context, in *common.PersonIDParam, opts ...grpc.CallOption) (*emptypb.Empty, error)
 	// 发送消息
 	SendMessage(ctx context.Context, in *SendMessageRequest, opts ...grpc.CallOption) (*common.SendMessageReply, error)
-	// 发送消息 new
-	Send(ctx context.Context, in *common.SendMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
-	// 获取到后将对应数据变为已读
-	GetIsRead(ctx context.Context, in *common.ChatIsReadInfo, opts ...grpc.CallOption) (*emptypb.Empty, error)
-	// 用户进入房间
-	GotoRoom(ctx context.Context, in *common.GoToRoom, opts ...grpc.CallOption) (*emptypb.Empty, error)
 }
 
 type chatClient struct {
@@ -531,33 +525,6 @@ func (c *chatClient) SendMessage(ctx context.Context, in *SendMessageRequest, op
 	return out, nil
 }
 
-func (c *chatClient) Send(ctx context.Context, in *common.SendMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
-	out := new(emptypb.Empty)
-	err := c.cc.Invoke(ctx, "/api.chat.Chat/Send", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *chatClient) GetIsRead(ctx context.Context, in *common.ChatIsReadInfo, opts ...grpc.CallOption) (*emptypb.Empty, error) {
-	out := new(emptypb.Empty)
-	err := c.cc.Invoke(ctx, "/api.chat.Chat/GetIsRead", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *chatClient) GotoRoom(ctx context.Context, in *common.GoToRoom, opts ...grpc.CallOption) (*emptypb.Empty, error) {
-	out := new(emptypb.Empty)
-	err := c.cc.Invoke(ctx, "/api.chat.Chat/GotoRoom", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
 // ChatServer is the server API for Chat service.
 // All implementations must embed UnimplementedChatServer
 // for forward compatibility
@@ -652,12 +619,6 @@ type ChatServer interface {
 	DeleteScripByPersonID(context.Context, *common.PersonIDParam) (*emptypb.Empty, error)
 	// 发送消息
 	SendMessage(context.Context, *SendMessageRequest) (*common.SendMessageReply, error)
-	// 发送消息 new
-	Send(context.Context, *common.SendMessageRequest) (*emptypb.Empty, error)
-	// 获取到后将对应数据变为已读
-	GetIsRead(context.Context, *common.ChatIsReadInfo) (*emptypb.Empty, error)
-	// 用户进入房间
-	GotoRoom(context.Context, *common.GoToRoom) (*emptypb.Empty, error)
 	mustEmbedUnimplementedChatServer()
 }
 
@@ -800,15 +761,6 @@ func (UnimplementedChatServer) DeleteScripByPersonID(context.Context, *common.Pe
 func (UnimplementedChatServer) SendMessage(context.Context, *SendMessageRequest) (*common.SendMessageReply, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method SendMessage not implemented")
 }
-func (UnimplementedChatServer) Send(context.Context, *common.SendMessageRequest) (*emptypb.Empty, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method Send not implemented")
-}
-func (UnimplementedChatServer) GetIsRead(context.Context, *common.ChatIsReadInfo) (*emptypb.Empty, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method GetIsRead not implemented")
-}
-func (UnimplementedChatServer) GotoRoom(context.Context, *common.GoToRoom) (*emptypb.Empty, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method GotoRoom not implemented")
-}
 func (UnimplementedChatServer) mustEmbedUnimplementedChatServer() {}
 
 // UnsafeChatServer may be embedded to opt out of forward compatibility for this service.
@@ -1632,60 +1584,6 @@ func _Chat_SendMessage_Handler(srv interface{}, ctx context.Context, dec func(in
 	return interceptor(ctx, in, info, handler)
 }
 
-func _Chat_Send_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(common.SendMessageRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ChatServer).Send(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/api.chat.Chat/Send",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ChatServer).Send(ctx, req.(*common.SendMessageRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _Chat_GetIsRead_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(common.ChatIsReadInfo)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ChatServer).GetIsRead(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/api.chat.Chat/GetIsRead",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ChatServer).GetIsRead(ctx, req.(*common.ChatIsReadInfo))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _Chat_GotoRoom_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(common.GoToRoom)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ChatServer).GotoRoom(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/api.chat.Chat/GotoRoom",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ChatServer).GotoRoom(ctx, req.(*common.GoToRoom))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
 // Chat_ServiceDesc is the grpc.ServiceDesc for Chat service.
 // It's only intended for direct use with grpc.RegisterService,
 // and not to be introspected or modified (even as a copy)
@@ -1873,18 +1771,6 @@ var Chat_ServiceDesc = grpc.ServiceDesc{
 			MethodName: "SendMessage",
 			Handler:    _Chat_SendMessage_Handler,
 		},
-		{
-			MethodName: "Send",
-			Handler:    _Chat_Send_Handler,
-		},
-		{
-			MethodName: "GetIsRead",
-			Handler:    _Chat_GetIsRead_Handler,
-		},
-		{
-			MethodName: "GotoRoom",
-			Handler:    _Chat_GotoRoom_Handler,
-		},
 	},
 	Streams:  []grpc.StreamDesc{},
 	Metadata: "chat.proto",

+ 0 - 1372
api/online/online.pb.go

@@ -1,1372 +0,0 @@
-// Code generated by protoc-gen-go. DO NOT EDIT.
-// versions:
-// 	protoc-gen-go v1.28.1-devel
-// 	protoc        v3.21.8
-// source: online.proto
-
-package online
-
-import (
-	common "git.ikuban.com/server/pw-protobuf/api/common"
-	_ "google.golang.org/genproto/googleapis/api/annotations"
-	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
-	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
-	emptypb "google.golang.org/protobuf/types/known/emptypb"
-	reflect "reflect"
-	sync "sync"
-)
-
-const (
-	// Verify that this generated code is sufficiently up-to-date.
-	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
-	// Verify that runtime/protoimpl is sufficiently up-to-date.
-	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
-)
-
-type SendMessageInfo struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
-	RoomId  int64           `protobuf:"varint,1,opt,name=roomId,proto3" json:"roomId"`  // 房间ID
-	Message *common.Message `protobuf:"bytes,2,opt,name=message,proto3" json:"message"` // 消息
-	MsgType string          `protobuf:"bytes,3,opt,name=msgType,proto3" json:"msgType"` // 消息类型
-}
-
-func (x *SendMessageInfo) Reset() {
-	*x = SendMessageInfo{}
-	if protoimpl.UnsafeEnabled {
-		mi := &file_online_proto_msgTypes[0]
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		ms.StoreMessageInfo(mi)
-	}
-}
-
-func (x *SendMessageInfo) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*SendMessageInfo) ProtoMessage() {}
-
-func (x *SendMessageInfo) ProtoReflect() protoreflect.Message {
-	mi := &file_online_proto_msgTypes[0]
-	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 SendMessageInfo.ProtoReflect.Descriptor instead.
-func (*SendMessageInfo) Descriptor() ([]byte, []int) {
-	return file_online_proto_rawDescGZIP(), []int{0}
-}
-
-func (x *SendMessageInfo) GetRoomId() int64 {
-	if x != nil {
-		return x.RoomId
-	}
-	return 0
-}
-
-func (x *SendMessageInfo) GetMessage() *common.Message {
-	if x != nil && x.Message != nil {
-		return x.Message
-	}
-	return &common.Message{}
-}
-
-func (x *SendMessageInfo) GetMsgType() string {
-	if x != nil {
-		return x.MsgType
-	}
-	return ""
-}
-
-type ChatIsReadInfo struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
-	MessageId int64 `protobuf:"varint,1,opt,name=messageId,proto3" json:"messageId"` // 消息的ID
-	RoomId    int64 `protobuf:"varint,2,opt,name=roomId,proto3" json:"roomId"`       // 房间ID
-}
-
-func (x *ChatIsReadInfo) Reset() {
-	*x = ChatIsReadInfo{}
-	if protoimpl.UnsafeEnabled {
-		mi := &file_online_proto_msgTypes[1]
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		ms.StoreMessageInfo(mi)
-	}
-}
-
-func (x *ChatIsReadInfo) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*ChatIsReadInfo) ProtoMessage() {}
-
-func (x *ChatIsReadInfo) ProtoReflect() protoreflect.Message {
-	mi := &file_online_proto_msgTypes[1]
-	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 ChatIsReadInfo.ProtoReflect.Descriptor instead.
-func (*ChatIsReadInfo) Descriptor() ([]byte, []int) {
-	return file_online_proto_rawDescGZIP(), []int{1}
-}
-
-func (x *ChatIsReadInfo) GetMessageId() int64 {
-	if x != nil {
-		return x.MessageId
-	}
-	return 0
-}
-
-func (x *ChatIsReadInfo) GetRoomId() int64 {
-	if x != nil {
-		return x.RoomId
-	}
-	return 0
-}
-
-type GotoRoomInfo struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
-	RoomId int64 `protobuf:"varint,1,opt,name=roomId,proto3" json:"roomId"` // 房间ID
-}
-
-func (x *GotoRoomInfo) Reset() {
-	*x = GotoRoomInfo{}
-	if protoimpl.UnsafeEnabled {
-		mi := &file_online_proto_msgTypes[2]
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		ms.StoreMessageInfo(mi)
-	}
-}
-
-func (x *GotoRoomInfo) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*GotoRoomInfo) ProtoMessage() {}
-
-func (x *GotoRoomInfo) ProtoReflect() protoreflect.Message {
-	mi := &file_online_proto_msgTypes[2]
-	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 GotoRoomInfo.ProtoReflect.Descriptor instead.
-func (*GotoRoomInfo) Descriptor() ([]byte, []int) {
-	return file_online_proto_rawDescGZIP(), []int{2}
-}
-
-func (x *GotoRoomInfo) GetRoomId() int64 {
-	if x != nil {
-		return x.RoomId
-	}
-	return 0
-}
-
-type ReceiveRequest struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
-	Method       string `protobuf:"bytes,1,opt,name=method,proto3" json:"method"` // 路由
-	Data         []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data"`     // 数据
-	WebsocketTag string `protobuf:"bytes,3,opt,name=websocketTag,proto3" json:"websocketTag"`
-}
-
-func (x *ReceiveRequest) Reset() {
-	*x = ReceiveRequest{}
-	if protoimpl.UnsafeEnabled {
-		mi := &file_online_proto_msgTypes[3]
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		ms.StoreMessageInfo(mi)
-	}
-}
-
-func (x *ReceiveRequest) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*ReceiveRequest) ProtoMessage() {}
-
-func (x *ReceiveRequest) ProtoReflect() protoreflect.Message {
-	mi := &file_online_proto_msgTypes[3]
-	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 ReceiveRequest.ProtoReflect.Descriptor instead.
-func (*ReceiveRequest) Descriptor() ([]byte, []int) {
-	return file_online_proto_rawDescGZIP(), []int{3}
-}
-
-func (x *ReceiveRequest) GetMethod() string {
-	if x != nil {
-		return x.Method
-	}
-	return ""
-}
-
-func (x *ReceiveRequest) GetData() []byte {
-	if x != nil {
-		return x.Data
-	}
-	return make([]byte, 0)
-}
-
-func (x *ReceiveRequest) GetWebsocketTag() string {
-	if x != nil {
-		return x.WebsocketTag
-	}
-	return ""
-}
-
-type ReceiveReply struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-}
-
-func (x *ReceiveReply) Reset() {
-	*x = ReceiveReply{}
-	if protoimpl.UnsafeEnabled {
-		mi := &file_online_proto_msgTypes[4]
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		ms.StoreMessageInfo(mi)
-	}
-}
-
-func (x *ReceiveReply) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*ReceiveReply) ProtoMessage() {}
-
-func (x *ReceiveReply) ProtoReflect() protoreflect.Message {
-	mi := &file_online_proto_msgTypes[4]
-	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 ReceiveReply.ProtoReflect.Descriptor instead.
-func (*ReceiveReply) Descriptor() ([]byte, []int) {
-	return file_online_proto_rawDescGZIP(), []int{4}
-}
-
-type OnlinePersonMessageReply struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
-	List []*OnlinePersonMessageInfo `protobuf:"bytes,1,rep,name=list,proto3" json:"list"`
-}
-
-func (x *OnlinePersonMessageReply) Reset() {
-	*x = OnlinePersonMessageReply{}
-	if protoimpl.UnsafeEnabled {
-		mi := &file_online_proto_msgTypes[5]
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		ms.StoreMessageInfo(mi)
-	}
-}
-
-func (x *OnlinePersonMessageReply) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*OnlinePersonMessageReply) ProtoMessage() {}
-
-func (x *OnlinePersonMessageReply) ProtoReflect() protoreflect.Message {
-	mi := &file_online_proto_msgTypes[5]
-	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 OnlinePersonMessageReply.ProtoReflect.Descriptor instead.
-func (*OnlinePersonMessageReply) Descriptor() ([]byte, []int) {
-	return file_online_proto_rawDescGZIP(), []int{5}
-}
-
-func (x *OnlinePersonMessageReply) GetList() []*OnlinePersonMessageInfo {
-	if x != nil {
-		return x.List
-	}
-	return make([]*OnlinePersonMessageInfo, 0)
-}
-
-type OnlinePersonMessageInfo struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
-	TodayMatchedNum int64  `protobuf:"varint,1,opt,name=todayMatchedNum,proto3" json:"todayMatchedNum"` // 今日被匹配数
-	PersonId        string `protobuf:"bytes,2,opt,name=personId,proto3" json:"personId"`
-	Weight          int64  `protobuf:"varint,3,opt,name=weight,proto3" json:"weight"`              // 权重
-	WorkingStatus   string `protobuf:"bytes,4,opt,name=workingStatus,proto3" json:"workingStatus"` // 工作状态
-	Sex             int64  `protobuf:"varint,5,opt,name=sex,proto3" json:"sex"`                    // 性别
-	Age             int64  `protobuf:"varint,6,opt,name=age,proto3" json:"age"`                    // 年龄
-	Province        string `protobuf:"bytes,7,opt,name=province,proto3" json:"province"`           // 省
-	City            string `protobuf:"bytes,8,opt,name=city,proto3" json:"city"`                   // 市
-}
-
-func (x *OnlinePersonMessageInfo) Reset() {
-	*x = OnlinePersonMessageInfo{}
-	if protoimpl.UnsafeEnabled {
-		mi := &file_online_proto_msgTypes[6]
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		ms.StoreMessageInfo(mi)
-	}
-}
-
-func (x *OnlinePersonMessageInfo) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*OnlinePersonMessageInfo) ProtoMessage() {}
-
-func (x *OnlinePersonMessageInfo) ProtoReflect() protoreflect.Message {
-	mi := &file_online_proto_msgTypes[6]
-	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 OnlinePersonMessageInfo.ProtoReflect.Descriptor instead.
-func (*OnlinePersonMessageInfo) Descriptor() ([]byte, []int) {
-	return file_online_proto_rawDescGZIP(), []int{6}
-}
-
-func (x *OnlinePersonMessageInfo) GetTodayMatchedNum() int64 {
-	if x != nil {
-		return x.TodayMatchedNum
-	}
-	return 0
-}
-
-func (x *OnlinePersonMessageInfo) GetPersonId() string {
-	if x != nil {
-		return x.PersonId
-	}
-	return ""
-}
-
-func (x *OnlinePersonMessageInfo) GetWeight() int64 {
-	if x != nil {
-		return x.Weight
-	}
-	return 0
-}
-
-func (x *OnlinePersonMessageInfo) GetWorkingStatus() string {
-	if x != nil {
-		return x.WorkingStatus
-	}
-	return ""
-}
-
-func (x *OnlinePersonMessageInfo) GetSex() int64 {
-	if x != nil {
-		return x.Sex
-	}
-	return 0
-}
-
-func (x *OnlinePersonMessageInfo) GetAge() int64 {
-	if x != nil {
-		return x.Age
-	}
-	return 0
-}
-
-func (x *OnlinePersonMessageInfo) GetProvince() string {
-	if x != nil {
-		return x.Province
-	}
-	return ""
-}
-
-func (x *OnlinePersonMessageInfo) GetCity() string {
-	if x != nil {
-		return x.City
-	}
-	return ""
-}
-
-type OnlinePersonReply struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
-	UserManNum   int64 `protobuf:"varint,1,opt,name=userManNum,proto3" json:"userManNum"`     // 男用户在线数
-	UserWomanNum int64 `protobuf:"varint,2,opt,name=userWomanNum,proto3" json:"userWomanNum"` // 女用户在线数
-	UserOtherNum int64 `protobuf:"varint,3,opt,name=userOtherNum,proto3" json:"userOtherNum"` // 未填写性别的用户在线数
-}
-
-func (x *OnlinePersonReply) Reset() {
-	*x = OnlinePersonReply{}
-	if protoimpl.UnsafeEnabled {
-		mi := &file_online_proto_msgTypes[7]
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		ms.StoreMessageInfo(mi)
-	}
-}
-
-func (x *OnlinePersonReply) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*OnlinePersonReply) ProtoMessage() {}
-
-func (x *OnlinePersonReply) ProtoReflect() protoreflect.Message {
-	mi := &file_online_proto_msgTypes[7]
-	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 OnlinePersonReply.ProtoReflect.Descriptor instead.
-func (*OnlinePersonReply) Descriptor() ([]byte, []int) {
-	return file_online_proto_rawDescGZIP(), []int{7}
-}
-
-func (x *OnlinePersonReply) GetUserManNum() int64 {
-	if x != nil {
-		return x.UserManNum
-	}
-	return 0
-}
-
-func (x *OnlinePersonReply) GetUserWomanNum() int64 {
-	if x != nil {
-		return x.UserWomanNum
-	}
-	return 0
-}
-
-func (x *OnlinePersonReply) GetUserOtherNum() int64 {
-	if x != nil {
-		return x.UserOtherNum
-	}
-	return 0
-}
-
-type CheckIsOnlineRequest struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
-	UserId string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId"` // 身份ID
-}
-
-func (x *CheckIsOnlineRequest) Reset() {
-	*x = CheckIsOnlineRequest{}
-	if protoimpl.UnsafeEnabled {
-		mi := &file_online_proto_msgTypes[8]
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		ms.StoreMessageInfo(mi)
-	}
-}
-
-func (x *CheckIsOnlineRequest) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*CheckIsOnlineRequest) ProtoMessage() {}
-
-func (x *CheckIsOnlineRequest) ProtoReflect() protoreflect.Message {
-	mi := &file_online_proto_msgTypes[8]
-	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 CheckIsOnlineRequest.ProtoReflect.Descriptor instead.
-func (*CheckIsOnlineRequest) Descriptor() ([]byte, []int) {
-	return file_online_proto_rawDescGZIP(), []int{8}
-}
-
-func (x *CheckIsOnlineRequest) GetUserId() string {
-	if x != nil {
-		return x.UserId
-	}
-	return ""
-}
-
-type CheckIsOnlineByIDsParam struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
-	UserIds []string `protobuf:"bytes,1,rep,name=userIds,proto3" json:"userIds"` // 身份ID
-}
-
-func (x *CheckIsOnlineByIDsParam) Reset() {
-	*x = CheckIsOnlineByIDsParam{}
-	if protoimpl.UnsafeEnabled {
-		mi := &file_online_proto_msgTypes[9]
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		ms.StoreMessageInfo(mi)
-	}
-}
-
-func (x *CheckIsOnlineByIDsParam) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*CheckIsOnlineByIDsParam) ProtoMessage() {}
-
-func (x *CheckIsOnlineByIDsParam) ProtoReflect() protoreflect.Message {
-	mi := &file_online_proto_msgTypes[9]
-	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 CheckIsOnlineByIDsParam.ProtoReflect.Descriptor instead.
-func (*CheckIsOnlineByIDsParam) Descriptor() ([]byte, []int) {
-	return file_online_proto_rawDescGZIP(), []int{9}
-}
-
-func (x *CheckIsOnlineByIDsParam) GetUserIds() []string {
-	if x != nil {
-		return x.UserIds
-	}
-	return make([]string, 0)
-}
-
-type CheckIsOnlineReply struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
-	IsOnline bool `protobuf:"varint,1,opt,name=isOnline,proto3" json:"isOnline"` // 是否在线
-}
-
-func (x *CheckIsOnlineReply) Reset() {
-	*x = CheckIsOnlineReply{}
-	if protoimpl.UnsafeEnabled {
-		mi := &file_online_proto_msgTypes[10]
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		ms.StoreMessageInfo(mi)
-	}
-}
-
-func (x *CheckIsOnlineReply) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*CheckIsOnlineReply) ProtoMessage() {}
-
-func (x *CheckIsOnlineReply) ProtoReflect() protoreflect.Message {
-	mi := &file_online_proto_msgTypes[10]
-	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 CheckIsOnlineReply.ProtoReflect.Descriptor instead.
-func (*CheckIsOnlineReply) Descriptor() ([]byte, []int) {
-	return file_online_proto_rawDescGZIP(), []int{10}
-}
-
-func (x *CheckIsOnlineReply) GetIsOnline() bool {
-	if x != nil {
-		return x.IsOnline
-	}
-	return false
-}
-
-type UpdateWorkingStatusRequest struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
-	Id            string `protobuf:"bytes,1,opt,name=id,proto3" json:"id"`
-	WorkingStatus string `protobuf:"bytes,2,opt,name=workingStatus,proto3" json:"workingStatus"`
-}
-
-func (x *UpdateWorkingStatusRequest) Reset() {
-	*x = UpdateWorkingStatusRequest{}
-	if protoimpl.UnsafeEnabled {
-		mi := &file_online_proto_msgTypes[11]
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		ms.StoreMessageInfo(mi)
-	}
-}
-
-func (x *UpdateWorkingStatusRequest) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*UpdateWorkingStatusRequest) ProtoMessage() {}
-
-func (x *UpdateWorkingStatusRequest) ProtoReflect() protoreflect.Message {
-	mi := &file_online_proto_msgTypes[11]
-	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 UpdateWorkingStatusRequest.ProtoReflect.Descriptor instead.
-func (*UpdateWorkingStatusRequest) Descriptor() ([]byte, []int) {
-	return file_online_proto_rawDescGZIP(), []int{11}
-}
-
-func (x *UpdateWorkingStatusRequest) GetId() string {
-	if x != nil {
-		return x.Id
-	}
-	return ""
-}
-
-func (x *UpdateWorkingStatusRequest) GetWorkingStatus() string {
-	if x != nil {
-		return x.WorkingStatus
-	}
-	return ""
-}
-
-type UpdateWeightRequest struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
-	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id"`
-	Weight int64  `protobuf:"varint,2,opt,name=weight,proto3" json:"weight"`
-}
-
-func (x *UpdateWeightRequest) Reset() {
-	*x = UpdateWeightRequest{}
-	if protoimpl.UnsafeEnabled {
-		mi := &file_online_proto_msgTypes[12]
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		ms.StoreMessageInfo(mi)
-	}
-}
-
-func (x *UpdateWeightRequest) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*UpdateWeightRequest) ProtoMessage() {}
-
-func (x *UpdateWeightRequest) ProtoReflect() protoreflect.Message {
-	mi := &file_online_proto_msgTypes[12]
-	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 UpdateWeightRequest.ProtoReflect.Descriptor instead.
-func (*UpdateWeightRequest) Descriptor() ([]byte, []int) {
-	return file_online_proto_rawDescGZIP(), []int{12}
-}
-
-func (x *UpdateWeightRequest) GetId() string {
-	if x != nil {
-		return x.Id
-	}
-	return ""
-}
-
-func (x *UpdateWeightRequest) GetWeight() int64 {
-	if x != nil {
-		return x.Weight
-	}
-	return 0
-}
-
-type UpdateTodayMatchedNumRequest struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
-	Id              string `protobuf:"bytes,1,opt,name=id,proto3" json:"id"`
-	TodayMatchedNum int64  `protobuf:"varint,2,opt,name=todayMatchedNum,proto3" json:"todayMatchedNum"`
-}
-
-func (x *UpdateTodayMatchedNumRequest) Reset() {
-	*x = UpdateTodayMatchedNumRequest{}
-	if protoimpl.UnsafeEnabled {
-		mi := &file_online_proto_msgTypes[13]
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		ms.StoreMessageInfo(mi)
-	}
-}
-
-func (x *UpdateTodayMatchedNumRequest) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*UpdateTodayMatchedNumRequest) ProtoMessage() {}
-
-func (x *UpdateTodayMatchedNumRequest) ProtoReflect() protoreflect.Message {
-	mi := &file_online_proto_msgTypes[13]
-	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 UpdateTodayMatchedNumRequest.ProtoReflect.Descriptor instead.
-func (*UpdateTodayMatchedNumRequest) Descriptor() ([]byte, []int) {
-	return file_online_proto_rawDescGZIP(), []int{13}
-}
-
-func (x *UpdateTodayMatchedNumRequest) GetId() string {
-	if x != nil {
-		return x.Id
-	}
-	return ""
-}
-
-func (x *UpdateTodayMatchedNumRequest) GetTodayMatchedNum() int64 {
-	if x != nil {
-		return x.TodayMatchedNum
-	}
-	return 0
-}
-
-type SendMsgRequest struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
-	Id           string `protobuf:"bytes,1,opt,name=id,proto3" json:"id"`
-	Method       string `protobuf:"bytes,2,opt,name=method,proto3" json:"method"`
-	Data         []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data"`
-	Code         int32  `protobuf:"varint,4,opt,name=code,proto3" json:"code"`
-	Message      string `protobuf:"bytes,5,opt,name=message,proto3" json:"message"`
-	WebsocketTag string `protobuf:"bytes,6,opt,name=websocketTag,proto3" json:"websocketTag"`
-}
-
-func (x *SendMsgRequest) Reset() {
-	*x = SendMsgRequest{}
-	if protoimpl.UnsafeEnabled {
-		mi := &file_online_proto_msgTypes[14]
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		ms.StoreMessageInfo(mi)
-	}
-}
-
-func (x *SendMsgRequest) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*SendMsgRequest) ProtoMessage() {}
-
-func (x *SendMsgRequest) ProtoReflect() protoreflect.Message {
-	mi := &file_online_proto_msgTypes[14]
-	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 SendMsgRequest.ProtoReflect.Descriptor instead.
-func (*SendMsgRequest) Descriptor() ([]byte, []int) {
-	return file_online_proto_rawDescGZIP(), []int{14}
-}
-
-func (x *SendMsgRequest) GetId() string {
-	if x != nil {
-		return x.Id
-	}
-	return ""
-}
-
-func (x *SendMsgRequest) GetMethod() string {
-	if x != nil {
-		return x.Method
-	}
-	return ""
-}
-
-func (x *SendMsgRequest) GetData() []byte {
-	if x != nil {
-		return x.Data
-	}
-	return make([]byte, 0)
-}
-
-func (x *SendMsgRequest) GetCode() int32 {
-	if x != nil {
-		return x.Code
-	}
-	return 0
-}
-
-func (x *SendMsgRequest) GetMessage() string {
-	if x != nil {
-		return x.Message
-	}
-	return ""
-}
-
-func (x *SendMsgRequest) GetWebsocketTag() string {
-	if x != nil {
-		return x.WebsocketTag
-	}
-	return ""
-}
-
-type SendMsgReply struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-}
-
-func (x *SendMsgReply) Reset() {
-	*x = SendMsgReply{}
-	if protoimpl.UnsafeEnabled {
-		mi := &file_online_proto_msgTypes[15]
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		ms.StoreMessageInfo(mi)
-	}
-}
-
-func (x *SendMsgReply) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*SendMsgReply) ProtoMessage() {}
-
-func (x *SendMsgReply) ProtoReflect() protoreflect.Message {
-	mi := &file_online_proto_msgTypes[15]
-	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 SendMsgReply.ProtoReflect.Descriptor instead.
-func (*SendMsgReply) Descriptor() ([]byte, []int) {
-	return file_online_proto_rawDescGZIP(), []int{15}
-}
-
-var File_online_proto protoreflect.FileDescriptor
-
-var file_online_proto_rawDesc = []byte{
-	0x0a, 0x0c, 0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x0a,
-	0x61, 0x70, 0x69, 0x2e, 0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67,
-	0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f,
-	0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
-	0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e,
-	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x6f, 0x6d, 0x6d, 0x6f,
-	0x6e, 0x2f, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x72,
-	0x0a, 0x0f, 0x53, 0x65, 0x6e, 0x64, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x49, 0x6e, 0x66,
-	0x6f, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x6f, 0x6f, 0x6d, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28,
-	0x03, 0x52, 0x06, 0x72, 0x6f, 0x6f, 0x6d, 0x49, 0x64, 0x12, 0x2d, 0x0a, 0x07, 0x6d, 0x65, 0x73,
-	0x73, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x13, 0x2e, 0x61, 0x70, 0x69,
-	0x2e, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52,
-	0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x73, 0x67, 0x54,
-	0x79, 0x70, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x73, 0x67, 0x54, 0x79,
-	0x70, 0x65, 0x22, 0x46, 0x0a, 0x0e, 0x43, 0x68, 0x61, 0x74, 0x49, 0x73, 0x52, 0x65, 0x61, 0x64,
-	0x49, 0x6e, 0x66, 0x6f, 0x12, 0x1c, 0x0a, 0x09, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x49,
-	0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65,
-	0x49, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x6f, 0x6f, 0x6d, 0x49, 0x64, 0x18, 0x02, 0x20, 0x01,
-	0x28, 0x03, 0x52, 0x06, 0x72, 0x6f, 0x6f, 0x6d, 0x49, 0x64, 0x22, 0x26, 0x0a, 0x0c, 0x47, 0x6f,
-	0x74, 0x6f, 0x52, 0x6f, 0x6f, 0x6d, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x6f,
-	0x6f, 0x6d, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x72, 0x6f, 0x6f, 0x6d,
-	0x49, 0x64, 0x22, 0x60, 0x0a, 0x0e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x52, 0x65, 0x71,
-	0x75, 0x65, 0x73, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x18, 0x01,
-	0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x12, 0x12, 0x0a, 0x04,
-	0x64, 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61,
-	0x12, 0x22, 0x0a, 0x0c, 0x77, 0x65, 0x62, 0x73, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x54, 0x61, 0x67,
-	0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x77, 0x65, 0x62, 0x73, 0x6f, 0x63, 0x6b, 0x65,
-	0x74, 0x54, 0x61, 0x67, 0x22, 0x0e, 0x0a, 0x0c, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x52,
-	0x65, 0x70, 0x6c, 0x79, 0x22, 0x53, 0x0a, 0x18, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x50, 0x65,
-	0x72, 0x73, 0x6f, 0x6e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x65, 0x70, 0x6c, 0x79,
-	0x12, 0x37, 0x0a, 0x04, 0x6c, 0x69, 0x73, 0x74, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x23,
-	0x2e, 0x61, 0x70, 0x69, 0x2e, 0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x2e, 0x4f, 0x6e, 0x6c, 0x69,
-	0x6e, 0x65, 0x50, 0x65, 0x72, 0x73, 0x6f, 0x6e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x49,
-	0x6e, 0x66, 0x6f, 0x52, 0x04, 0x6c, 0x69, 0x73, 0x74, 0x22, 0xf1, 0x01, 0x0a, 0x17, 0x4f, 0x6e,
-	0x6c, 0x69, 0x6e, 0x65, 0x50, 0x65, 0x72, 0x73, 0x6f, 0x6e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67,
-	0x65, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x28, 0x0a, 0x0f, 0x74, 0x6f, 0x64, 0x61, 0x79, 0x4d, 0x61,
-	0x74, 0x63, 0x68, 0x65, 0x64, 0x4e, 0x75, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0f,
-	0x74, 0x6f, 0x64, 0x61, 0x79, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x64, 0x4e, 0x75, 0x6d, 0x12,
-	0x1a, 0x0a, 0x08, 0x70, 0x65, 0x72, 0x73, 0x6f, 0x6e, 0x49, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28,
-	0x09, 0x52, 0x08, 0x70, 0x65, 0x72, 0x73, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x77,
-	0x65, 0x69, 0x67, 0x68, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x77, 0x65, 0x69,
-	0x67, 0x68, 0x74, 0x12, 0x24, 0x0a, 0x0d, 0x77, 0x6f, 0x72, 0x6b, 0x69, 0x6e, 0x67, 0x53, 0x74,
-	0x61, 0x74, 0x75, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x77, 0x6f, 0x72, 0x6b,
-	0x69, 0x6e, 0x67, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x10, 0x0a, 0x03, 0x73, 0x65, 0x78,
-	0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x03, 0x73, 0x65, 0x78, 0x12, 0x10, 0x0a, 0x03, 0x61,
-	0x67, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x03, 0x52, 0x03, 0x61, 0x67, 0x65, 0x12, 0x1a, 0x0a,
-	0x08, 0x70, 0x72, 0x6f, 0x76, 0x69, 0x6e, 0x63, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52,
-	0x08, 0x70, 0x72, 0x6f, 0x76, 0x69, 0x6e, 0x63, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x63, 0x69, 0x74,
-	0x79, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x63, 0x69, 0x74, 0x79, 0x22, 0x7b, 0x0a,
-	0x11, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x50, 0x65, 0x72, 0x73, 0x6f, 0x6e, 0x52, 0x65, 0x70,
-	0x6c, 0x79, 0x12, 0x1e, 0x0a, 0x0a, 0x75, 0x73, 0x65, 0x72, 0x4d, 0x61, 0x6e, 0x4e, 0x75, 0x6d,
-	0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0a, 0x75, 0x73, 0x65, 0x72, 0x4d, 0x61, 0x6e, 0x4e,
-	0x75, 0x6d, 0x12, 0x22, 0x0a, 0x0c, 0x75, 0x73, 0x65, 0x72, 0x57, 0x6f, 0x6d, 0x61, 0x6e, 0x4e,
-	0x75, 0x6d, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0c, 0x75, 0x73, 0x65, 0x72, 0x57, 0x6f,
-	0x6d, 0x61, 0x6e, 0x4e, 0x75, 0x6d, 0x12, 0x22, 0x0a, 0x0c, 0x75, 0x73, 0x65, 0x72, 0x4f, 0x74,
-	0x68, 0x65, 0x72, 0x4e, 0x75, 0x6d, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0c, 0x75, 0x73,
-	0x65, 0x72, 0x4f, 0x74, 0x68, 0x65, 0x72, 0x4e, 0x75, 0x6d, 0x22, 0x2e, 0x0a, 0x14, 0x43, 0x68,
-	0x65, 0x63, 0x6b, 0x49, 0x73, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65,
-	0x73, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x75, 0x73, 0x65, 0x72, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01,
-	0x28, 0x09, 0x52, 0x06, 0x75, 0x73, 0x65, 0x72, 0x49, 0x64, 0x22, 0x33, 0x0a, 0x17, 0x43, 0x68,
-	0x65, 0x63, 0x6b, 0x49, 0x73, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x42, 0x79, 0x49, 0x44, 0x73,
-	0x50, 0x61, 0x72, 0x61, 0x6d, 0x12, 0x18, 0x0a, 0x07, 0x75, 0x73, 0x65, 0x72, 0x49, 0x64, 0x73,
-	0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x07, 0x75, 0x73, 0x65, 0x72, 0x49, 0x64, 0x73, 0x22,
-	0x30, 0x0a, 0x12, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x49, 0x73, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65,
-	0x52, 0x65, 0x70, 0x6c, 0x79, 0x12, 0x1a, 0x0a, 0x08, 0x69, 0x73, 0x4f, 0x6e, 0x6c, 0x69, 0x6e,
-	0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x08, 0x69, 0x73, 0x4f, 0x6e, 0x6c, 0x69, 0x6e,
-	0x65, 0x22, 0x52, 0x0a, 0x1a, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x57, 0x6f, 0x72, 0x6b, 0x69,
-	0x6e, 0x67, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
-	0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x12,
-	0x24, 0x0a, 0x0d, 0x77, 0x6f, 0x72, 0x6b, 0x69, 0x6e, 0x67, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73,
-	0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x77, 0x6f, 0x72, 0x6b, 0x69, 0x6e, 0x67, 0x53,
-	0x74, 0x61, 0x74, 0x75, 0x73, 0x22, 0x3d, 0x0a, 0x13, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x57,
-	0x65, 0x69, 0x67, 0x68, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x0e, 0x0a, 0x02,
-	0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x12, 0x16, 0x0a, 0x06,
-	0x77, 0x65, 0x69, 0x67, 0x68, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x77, 0x65,
-	0x69, 0x67, 0x68, 0x74, 0x22, 0x58, 0x0a, 0x1c, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x54, 0x6f,
-	0x64, 0x61, 0x79, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x64, 0x4e, 0x75, 0x6d, 0x52, 0x65, 0x71,
-	0x75, 0x65, 0x73, 0x74, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
-	0x52, 0x02, 0x69, 0x64, 0x12, 0x28, 0x0a, 0x0f, 0x74, 0x6f, 0x64, 0x61, 0x79, 0x4d, 0x61, 0x74,
-	0x63, 0x68, 0x65, 0x64, 0x4e, 0x75, 0x6d, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0f, 0x74,
-	0x6f, 0x64, 0x61, 0x79, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x64, 0x4e, 0x75, 0x6d, 0x22, 0x9e,
-	0x01, 0x0a, 0x0e, 0x53, 0x65, 0x6e, 0x64, 0x4d, 0x73, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
-	0x74, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69,
-	0x64, 0x12, 0x16, 0x0a, 0x06, 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28,
-	0x09, 0x52, 0x06, 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74,
-	0x61, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x12, 0x12, 0x0a,
-	0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04, 0x63, 0x6f, 0x64,
-	0x65, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x05, 0x20, 0x01,
-	0x28, 0x09, 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x22, 0x0a, 0x0c, 0x77,
-	0x65, 0x62, 0x73, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x54, 0x61, 0x67, 0x18, 0x06, 0x20, 0x01, 0x28,
-	0x09, 0x52, 0x0c, 0x77, 0x65, 0x62, 0x73, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x54, 0x61, 0x67, 0x22,
-	0x0e, 0x0a, 0x0c, 0x53, 0x65, 0x6e, 0x64, 0x4d, 0x73, 0x67, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x32,
-	0xe1, 0x06, 0x0a, 0x06, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x12, 0x5f, 0x0a, 0x07, 0x52, 0x65,
-	0x63, 0x65, 0x69, 0x76, 0x65, 0x12, 0x1a, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x6f, 0x6e, 0x6c, 0x69,
-	0x6e, 0x65, 0x2e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
-	0x74, 0x1a, 0x18, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x2e, 0x52,
-	0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x1e, 0x82, 0xd3, 0xe4,
-	0x93, 0x02, 0x18, 0x22, 0x13, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65,
-	0x2f, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x3a, 0x01, 0x2a, 0x12, 0x41, 0x0a, 0x07, 0x53,
-	0x65, 0x6e, 0x64, 0x4d, 0x73, 0x67, 0x12, 0x1a, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x6f, 0x6e, 0x6c,
-	0x69, 0x6e, 0x65, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x4d, 0x73, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65,
-	0x73, 0x74, 0x1a, 0x18, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x2e,
-	0x53, 0x65, 0x6e, 0x64, 0x4d, 0x73, 0x67, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x00, 0x12, 0x53,
-	0x0a, 0x0d, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x49, 0x73, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x12,
-	0x20, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x2e, 0x43, 0x68, 0x65,
-	0x63, 0x6b, 0x49, 0x73, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
-	0x74, 0x1a, 0x1e, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x2e, 0x43,
-	0x68, 0x65, 0x63, 0x6b, 0x49, 0x73, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x70, 0x6c,
-	0x79, 0x22, 0x00, 0x12, 0x60, 0x0a, 0x12, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x49, 0x73, 0x4f, 0x6e,
-	0x6c, 0x69, 0x6e, 0x65, 0x42, 0x79, 0x49, 0x44, 0x73, 0x12, 0x23, 0x2e, 0x61, 0x70, 0x69, 0x2e,
-	0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x2e, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x49, 0x73, 0x4f, 0x6e,
-	0x6c, 0x69, 0x6e, 0x65, 0x42, 0x79, 0x49, 0x44, 0x73, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x1a, 0x23,
-	0x2e, 0x61, 0x70, 0x69, 0x2e, 0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x2e, 0x43, 0x68, 0x65, 0x63,
-	0x6b, 0x49, 0x73, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x42, 0x79, 0x49, 0x44, 0x73, 0x50, 0x61,
-	0x72, 0x61, 0x6d, 0x22, 0x00, 0x12, 0x50, 0x0a, 0x10, 0x46, 0x69, 0x6e, 0x64, 0x4f, 0x6e, 0x6c,
-	0x69, 0x6e, 0x65, 0x50, 0x65, 0x72, 0x73, 0x6f, 0x6e, 0x12, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
-	0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74,
-	0x79, 0x1a, 0x24, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x2e, 0x4f,
-	0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x50, 0x65, 0x72, 0x73, 0x6f, 0x6e, 0x4d, 0x65, 0x73, 0x73, 0x61,
-	0x67, 0x65, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x12, 0x5b, 0x0a, 0x1b, 0x46, 0x69, 0x6e, 0x64, 0x4f,
-	0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x43, 0x61, 0x6e, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x69, 0x6e, 0x67,
-	0x50, 0x65, 0x72, 0x73, 0x6f, 0x6e, 0x12, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
-	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x1a, 0x24,
-	0x2e, 0x61, 0x70, 0x69, 0x2e, 0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x2e, 0x4f, 0x6e, 0x6c, 0x69,
-	0x6e, 0x65, 0x50, 0x65, 0x72, 0x73, 0x6f, 0x6e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52,
-	0x65, 0x70, 0x6c, 0x79, 0x12, 0x4c, 0x0a, 0x13, 0x46, 0x69, 0x6e, 0x64, 0x4f, 0x6e, 0x6c, 0x69,
-	0x6e, 0x65, 0x50, 0x65, 0x72, 0x73, 0x6f, 0x6e, 0x4e, 0x75, 0x6d, 0x12, 0x16, 0x2e, 0x67, 0x6f,
-	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d,
-	0x70, 0x74, 0x79, 0x1a, 0x1d, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65,
-	0x2e, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x50, 0x65, 0x72, 0x73, 0x6f, 0x6e, 0x52, 0x65, 0x70,
-	0x6c, 0x79, 0x12, 0x57, 0x0a, 0x13, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x57, 0x6f, 0x72, 0x6b,
-	0x69, 0x6e, 0x67, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x26, 0x2e, 0x61, 0x70, 0x69, 0x2e,
-	0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x57, 0x6f, 0x72,
-	0x6b, 0x69, 0x6e, 0x67, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
-	0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
-	0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x49, 0x0a, 0x0c, 0x55,
-	0x70, 0x64, 0x61, 0x74, 0x65, 0x57, 0x65, 0x69, 0x67, 0x68, 0x74, 0x12, 0x1f, 0x2e, 0x61, 0x70,
-	0x69, 0x2e, 0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x57,
-	0x65, 0x69, 0x67, 0x68, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67,
-	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45,
-	0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x5b, 0x0a, 0x15, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65,
-	0x54, 0x6f, 0x64, 0x61, 0x79, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x64, 0x4e, 0x75, 0x6d, 0x12,
-	0x28, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x2e, 0x55, 0x70, 0x64,
-	0x61, 0x74, 0x65, 0x54, 0x6f, 0x64, 0x61, 0x79, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x64, 0x4e,
-	0x75, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
-	0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74,
-	0x79, 0x22, 0x00, 0x42, 0x43, 0x0a, 0x0a, 0x61, 0x70, 0x69, 0x2e, 0x6f, 0x6e, 0x6c, 0x69, 0x6e,
-	0x65, 0x50, 0x01, 0x5a, 0x33, 0x67, 0x69, 0x74, 0x2e, 0x69, 0x6b, 0x75, 0x62, 0x61, 0x6e, 0x2e,
-	0x63, 0x6f, 0x6d, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2f, 0x70, 0x77, 0x2d, 0x70, 0x72,
-	0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x6f, 0x6e, 0x6c, 0x69, 0x6e,
-	0x65, 0x3b, 0x6f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
-}
-
-var (
-	file_online_proto_rawDescOnce sync.Once
-	file_online_proto_rawDescData = file_online_proto_rawDesc
-)
-
-func file_online_proto_rawDescGZIP() []byte {
-	file_online_proto_rawDescOnce.Do(func() {
-		file_online_proto_rawDescData = protoimpl.X.CompressGZIP(file_online_proto_rawDescData)
-	})
-	return file_online_proto_rawDescData
-}
-
-var file_online_proto_msgTypes = make([]protoimpl.MessageInfo, 16)
-var file_online_proto_goTypes = []interface{}{
-	(*SendMessageInfo)(nil),              // 0: api.online.SendMessageInfo
-	(*ChatIsReadInfo)(nil),               // 1: api.online.ChatIsReadInfo
-	(*GotoRoomInfo)(nil),                 // 2: api.online.GotoRoomInfo
-	(*ReceiveRequest)(nil),               // 3: api.online.ReceiveRequest
-	(*ReceiveReply)(nil),                 // 4: api.online.ReceiveReply
-	(*OnlinePersonMessageReply)(nil),     // 5: api.online.OnlinePersonMessageReply
-	(*OnlinePersonMessageInfo)(nil),      // 6: api.online.OnlinePersonMessageInfo
-	(*OnlinePersonReply)(nil),            // 7: api.online.OnlinePersonReply
-	(*CheckIsOnlineRequest)(nil),         // 8: api.online.CheckIsOnlineRequest
-	(*CheckIsOnlineByIDsParam)(nil),      // 9: api.online.CheckIsOnlineByIDsParam
-	(*CheckIsOnlineReply)(nil),           // 10: api.online.CheckIsOnlineReply
-	(*UpdateWorkingStatusRequest)(nil),   // 11: api.online.UpdateWorkingStatusRequest
-	(*UpdateWeightRequest)(nil),          // 12: api.online.UpdateWeightRequest
-	(*UpdateTodayMatchedNumRequest)(nil), // 13: api.online.UpdateTodayMatchedNumRequest
-	(*SendMsgRequest)(nil),               // 14: api.online.SendMsgRequest
-	(*SendMsgReply)(nil),                 // 15: api.online.SendMsgReply
-	(*common.Message)(nil),               // 16: api.common.Message
-	(*emptypb.Empty)(nil),                // 17: google.protobuf.Empty
-}
-var file_online_proto_depIdxs = []int32{
-	16, // 0: api.online.SendMessageInfo.message:type_name -> api.common.Message
-	6,  // 1: api.online.OnlinePersonMessageReply.list:type_name -> api.online.OnlinePersonMessageInfo
-	3,  // 2: api.online.Online.Receive:input_type -> api.online.ReceiveRequest
-	14, // 3: api.online.Online.SendMsg:input_type -> api.online.SendMsgRequest
-	8,  // 4: api.online.Online.CheckIsOnline:input_type -> api.online.CheckIsOnlineRequest
-	9,  // 5: api.online.Online.CheckIsOnlineByIDs:input_type -> api.online.CheckIsOnlineByIDsParam
-	17, // 6: api.online.Online.FindOnlinePerson:input_type -> google.protobuf.Empty
-	17, // 7: api.online.Online.FindOnlineCanMatchingPerson:input_type -> google.protobuf.Empty
-	17, // 8: api.online.Online.FindOnlinePersonNum:input_type -> google.protobuf.Empty
-	11, // 9: api.online.Online.UpdateWorkingStatus:input_type -> api.online.UpdateWorkingStatusRequest
-	12, // 10: api.online.Online.UpdateWeight:input_type -> api.online.UpdateWeightRequest
-	13, // 11: api.online.Online.UpdateTodayMatchedNum:input_type -> api.online.UpdateTodayMatchedNumRequest
-	4,  // 12: api.online.Online.Receive:output_type -> api.online.ReceiveReply
-	15, // 13: api.online.Online.SendMsg:output_type -> api.online.SendMsgReply
-	10, // 14: api.online.Online.CheckIsOnline:output_type -> api.online.CheckIsOnlineReply
-	9,  // 15: api.online.Online.CheckIsOnlineByIDs:output_type -> api.online.CheckIsOnlineByIDsParam
-	5,  // 16: api.online.Online.FindOnlinePerson:output_type -> api.online.OnlinePersonMessageReply
-	5,  // 17: api.online.Online.FindOnlineCanMatchingPerson:output_type -> api.online.OnlinePersonMessageReply
-	7,  // 18: api.online.Online.FindOnlinePersonNum:output_type -> api.online.OnlinePersonReply
-	17, // 19: api.online.Online.UpdateWorkingStatus:output_type -> google.protobuf.Empty
-	17, // 20: api.online.Online.UpdateWeight:output_type -> google.protobuf.Empty
-	17, // 21: api.online.Online.UpdateTodayMatchedNum:output_type -> google.protobuf.Empty
-	12, // [12:22] is the sub-list for method output_type
-	2,  // [2:12] is the sub-list for method input_type
-	2,  // [2:2] is the sub-list for extension type_name
-	2,  // [2:2] is the sub-list for extension extendee
-	0,  // [0:2] is the sub-list for field type_name
-}
-
-func init() { file_online_proto_init() }
-func file_online_proto_init() {
-	if File_online_proto != nil {
-		return
-	}
-	if !protoimpl.UnsafeEnabled {
-		file_online_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*SendMessageInfo); i {
-			case 0:
-				return &v.state
-			case 1:
-				return &v.sizeCache
-			case 2:
-				return &v.unknownFields
-			default:
-				return nil
-			}
-		}
-		file_online_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*ChatIsReadInfo); i {
-			case 0:
-				return &v.state
-			case 1:
-				return &v.sizeCache
-			case 2:
-				return &v.unknownFields
-			default:
-				return nil
-			}
-		}
-		file_online_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*GotoRoomInfo); i {
-			case 0:
-				return &v.state
-			case 1:
-				return &v.sizeCache
-			case 2:
-				return &v.unknownFields
-			default:
-				return nil
-			}
-		}
-		file_online_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*ReceiveRequest); i {
-			case 0:
-				return &v.state
-			case 1:
-				return &v.sizeCache
-			case 2:
-				return &v.unknownFields
-			default:
-				return nil
-			}
-		}
-		file_online_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*ReceiveReply); i {
-			case 0:
-				return &v.state
-			case 1:
-				return &v.sizeCache
-			case 2:
-				return &v.unknownFields
-			default:
-				return nil
-			}
-		}
-		file_online_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*OnlinePersonMessageReply); i {
-			case 0:
-				return &v.state
-			case 1:
-				return &v.sizeCache
-			case 2:
-				return &v.unknownFields
-			default:
-				return nil
-			}
-		}
-		file_online_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*OnlinePersonMessageInfo); i {
-			case 0:
-				return &v.state
-			case 1:
-				return &v.sizeCache
-			case 2:
-				return &v.unknownFields
-			default:
-				return nil
-			}
-		}
-		file_online_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*OnlinePersonReply); i {
-			case 0:
-				return &v.state
-			case 1:
-				return &v.sizeCache
-			case 2:
-				return &v.unknownFields
-			default:
-				return nil
-			}
-		}
-		file_online_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*CheckIsOnlineRequest); i {
-			case 0:
-				return &v.state
-			case 1:
-				return &v.sizeCache
-			case 2:
-				return &v.unknownFields
-			default:
-				return nil
-			}
-		}
-		file_online_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*CheckIsOnlineByIDsParam); i {
-			case 0:
-				return &v.state
-			case 1:
-				return &v.sizeCache
-			case 2:
-				return &v.unknownFields
-			default:
-				return nil
-			}
-		}
-		file_online_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*CheckIsOnlineReply); i {
-			case 0:
-				return &v.state
-			case 1:
-				return &v.sizeCache
-			case 2:
-				return &v.unknownFields
-			default:
-				return nil
-			}
-		}
-		file_online_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*UpdateWorkingStatusRequest); i {
-			case 0:
-				return &v.state
-			case 1:
-				return &v.sizeCache
-			case 2:
-				return &v.unknownFields
-			default:
-				return nil
-			}
-		}
-		file_online_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*UpdateWeightRequest); i {
-			case 0:
-				return &v.state
-			case 1:
-				return &v.sizeCache
-			case 2:
-				return &v.unknownFields
-			default:
-				return nil
-			}
-		}
-		file_online_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*UpdateTodayMatchedNumRequest); i {
-			case 0:
-				return &v.state
-			case 1:
-				return &v.sizeCache
-			case 2:
-				return &v.unknownFields
-			default:
-				return nil
-			}
-		}
-		file_online_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*SendMsgRequest); i {
-			case 0:
-				return &v.state
-			case 1:
-				return &v.sizeCache
-			case 2:
-				return &v.unknownFields
-			default:
-				return nil
-			}
-		}
-		file_online_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*SendMsgReply); 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{
-		File: protoimpl.DescBuilder{
-			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
-			RawDescriptor: file_online_proto_rawDesc,
-			NumEnums:      0,
-			NumMessages:   16,
-			NumExtensions: 0,
-			NumServices:   1,
-		},
-		GoTypes:           file_online_proto_goTypes,
-		DependencyIndexes: file_online_proto_depIdxs,
-		MessageInfos:      file_online_proto_msgTypes,
-	}.Build()
-	File_online_proto = out.File
-	file_online_proto_rawDesc = nil
-	file_online_proto_goTypes = nil
-	file_online_proto_depIdxs = nil
-}

+ 0 - 124
api/online/online.proto

@@ -1,124 +0,0 @@
-syntax = "proto3";
-
-package api.online;
-
-import "google/api/annotations.proto";
-//import "google/protobuf/struct.proto";
-import "google/protobuf/empty.proto";
-import "api/common/common.proto";
-
-option go_package = "git.ikuban.com/server/pw-protobuf/api/online;online";
-option java_multiple_files = true;
-option java_package = "api.online";
-
-service Online {
-  // 用户上线
-  rpc Receive (ReceiveRequest) returns (ReceiveReply){
-    option (google.api.http) = {
-      post: "/api/online/receive",
-      body:"*"
-    };
-  };
-  // 发送消息
-  rpc SendMsg (SendMsgRequest) returns (SendMsgReply){};
-  // 检查是否在线
-  rpc CheckIsOnline (CheckIsOnlineRequest) returns (CheckIsOnlineReply){};
-  // 检查是否在线
-  rpc CheckIsOnlineByIDs (CheckIsOnlineByIDsParam) returns (CheckIsOnlineByIDsParam){};
-  // 查询在线用户信息列表
-  rpc FindOnlinePerson (google.protobuf.Empty) returns (OnlinePersonMessageReply);
-  // 查询可以匹配的在线用户信息列表
-  rpc FindOnlineCanMatchingPerson (google.protobuf.Empty) returns (OnlinePersonMessageReply);
-  // 查询在线多少人
-  rpc FindOnlinePersonNum (google.protobuf.Empty) returns (OnlinePersonReply);
-  // 更新工作状态
-  rpc UpdateWorkingStatus (UpdateWorkingStatusRequest) returns (google.protobuf.Empty){};
-  // 更新权重
-  rpc UpdateWeight (UpdateWeightRequest) returns (google.protobuf.Empty){};
-  // 更新每日被匹配数
-  rpc UpdateTodayMatchedNum (UpdateTodayMatchedNumRequest) returns (google.protobuf.Empty){};
-}
-
-message SendMessageInfo{
-  int64 roomId = 1;// 房间ID
-  common.Message message = 2;// 消息
-  string msgType = 3;// 消息类型
-}
-
-message ChatIsReadInfo{
-  int64 messageId = 1; // 消息的ID
-  int64 roomId = 2;    // 房间ID
-}
-
-message GotoRoomInfo{
-  int64 roomId = 1;    // 房间ID
-}
-
-message ReceiveRequest{
-  string method = 1; // 路由
-  bytes data = 2; // 数据
-  string websocketTag = 3;
-}
-
-message ReceiveReply{
-
-}
-
-message OnlinePersonMessageReply{
-  repeated OnlinePersonMessageInfo list = 1;
-}
-
-message OnlinePersonMessageInfo{
-  int64 todayMatchedNum = 1;// 今日被匹配数
-  string personId = 2;
-  int64 weight = 3;// 权重
-  string workingStatus = 4;// 工作状态
-  int64 sex = 5;// 性别
-  int64 age = 6;// 年龄
-  string province = 7;// 省
-  string city = 8;// 市
-}
-
-message OnlinePersonReply{
-  int64 userManNum = 1; // 男用户在线数
-  int64 userWomanNum = 2; // 女用户在线数
-  int64 userOtherNum = 3; // 未填写性别的用户在线数
-}
-
-message CheckIsOnlineRequest{
-  string userId = 1;// 身份ID
-}
-
-message CheckIsOnlineByIDsParam{
-  repeated string userIds = 1;// 身份ID
-}
-
-message CheckIsOnlineReply{
-  bool isOnline = 1;// 是否在线
-}
-
-message UpdateWorkingStatusRequest{
-  string id = 1;
-  string workingStatus = 2;
-}
-
-message UpdateWeightRequest{
-  string id = 1;
-  int64 weight = 2;
-}
-
-message UpdateTodayMatchedNumRequest{
-  string id = 1;
-  int64 todayMatchedNum = 2;
-}
-
-message SendMsgRequest{
-  string id = 1;
-  string method = 2;
-  bytes data = 3;
-  int32 code = 4;
-  string message = 5;
-  string websocketTag = 6;
-}
-
-message SendMsgReply{}

+ 0 - 446
api/online/online_grpc.pb.go

@@ -1,446 +0,0 @@
-// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
-
-package online
-
-import (
-	context "context"
-	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
-
-// OnlineClient is the client API for Online 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 OnlineClient interface {
-	// 用户上线
-	Receive(ctx context.Context, in *ReceiveRequest, opts ...grpc.CallOption) (*ReceiveReply, error)
-	// 发送消息
-	SendMsg(ctx context.Context, in *SendMsgRequest, opts ...grpc.CallOption) (*SendMsgReply, error)
-	// 检查是否在线
-	CheckIsOnline(ctx context.Context, in *CheckIsOnlineRequest, opts ...grpc.CallOption) (*CheckIsOnlineReply, error)
-	// 检查是否在线
-	CheckIsOnlineByIDs(ctx context.Context, in *CheckIsOnlineByIDsParam, opts ...grpc.CallOption) (*CheckIsOnlineByIDsParam, error)
-	// 查询在线用户信息列表
-	FindOnlinePerson(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*OnlinePersonMessageReply, error)
-	// 查询可以匹配的在线用户信息列表
-	FindOnlineCanMatchingPerson(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*OnlinePersonMessageReply, error)
-	// 查询在线多少人
-	FindOnlinePersonNum(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*OnlinePersonReply, error)
-	// 更新工作状态
-	UpdateWorkingStatus(ctx context.Context, in *UpdateWorkingStatusRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
-	// 更新权重
-	UpdateWeight(ctx context.Context, in *UpdateWeightRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
-	// 更新每日被匹配数
-	UpdateTodayMatchedNum(ctx context.Context, in *UpdateTodayMatchedNumRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
-}
-
-type onlineClient struct {
-	cc grpc.ClientConnInterface
-}
-
-func NewOnlineClient(cc grpc.ClientConnInterface) OnlineClient {
-	return &onlineClient{cc}
-}
-
-func (c *onlineClient) Receive(ctx context.Context, in *ReceiveRequest, opts ...grpc.CallOption) (*ReceiveReply, error) {
-	out := new(ReceiveReply)
-	err := c.cc.Invoke(ctx, "/api.online.Online/Receive", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *onlineClient) SendMsg(ctx context.Context, in *SendMsgRequest, opts ...grpc.CallOption) (*SendMsgReply, error) {
-	out := new(SendMsgReply)
-	err := c.cc.Invoke(ctx, "/api.online.Online/SendMsg", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *onlineClient) CheckIsOnline(ctx context.Context, in *CheckIsOnlineRequest, opts ...grpc.CallOption) (*CheckIsOnlineReply, error) {
-	out := new(CheckIsOnlineReply)
-	err := c.cc.Invoke(ctx, "/api.online.Online/CheckIsOnline", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *onlineClient) CheckIsOnlineByIDs(ctx context.Context, in *CheckIsOnlineByIDsParam, opts ...grpc.CallOption) (*CheckIsOnlineByIDsParam, error) {
-	out := new(CheckIsOnlineByIDsParam)
-	err := c.cc.Invoke(ctx, "/api.online.Online/CheckIsOnlineByIDs", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *onlineClient) FindOnlinePerson(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*OnlinePersonMessageReply, error) {
-	out := new(OnlinePersonMessageReply)
-	err := c.cc.Invoke(ctx, "/api.online.Online/FindOnlinePerson", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *onlineClient) FindOnlineCanMatchingPerson(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*OnlinePersonMessageReply, error) {
-	out := new(OnlinePersonMessageReply)
-	err := c.cc.Invoke(ctx, "/api.online.Online/FindOnlineCanMatchingPerson", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *onlineClient) FindOnlinePersonNum(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*OnlinePersonReply, error) {
-	out := new(OnlinePersonReply)
-	err := c.cc.Invoke(ctx, "/api.online.Online/FindOnlinePersonNum", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *onlineClient) UpdateWorkingStatus(ctx context.Context, in *UpdateWorkingStatusRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
-	out := new(emptypb.Empty)
-	err := c.cc.Invoke(ctx, "/api.online.Online/UpdateWorkingStatus", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *onlineClient) UpdateWeight(ctx context.Context, in *UpdateWeightRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
-	out := new(emptypb.Empty)
-	err := c.cc.Invoke(ctx, "/api.online.Online/UpdateWeight", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *onlineClient) UpdateTodayMatchedNum(ctx context.Context, in *UpdateTodayMatchedNumRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
-	out := new(emptypb.Empty)
-	err := c.cc.Invoke(ctx, "/api.online.Online/UpdateTodayMatchedNum", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-// OnlineServer is the server API for Online service.
-// All implementations must embed UnimplementedOnlineServer
-// for forward compatibility
-type OnlineServer interface {
-	// 用户上线
-	Receive(context.Context, *ReceiveRequest) (*ReceiveReply, error)
-	// 发送消息
-	SendMsg(context.Context, *SendMsgRequest) (*SendMsgReply, error)
-	// 检查是否在线
-	CheckIsOnline(context.Context, *CheckIsOnlineRequest) (*CheckIsOnlineReply, error)
-	// 检查是否在线
-	CheckIsOnlineByIDs(context.Context, *CheckIsOnlineByIDsParam) (*CheckIsOnlineByIDsParam, error)
-	// 查询在线用户信息列表
-	FindOnlinePerson(context.Context, *emptypb.Empty) (*OnlinePersonMessageReply, error)
-	// 查询可以匹配的在线用户信息列表
-	FindOnlineCanMatchingPerson(context.Context, *emptypb.Empty) (*OnlinePersonMessageReply, error)
-	// 查询在线多少人
-	FindOnlinePersonNum(context.Context, *emptypb.Empty) (*OnlinePersonReply, error)
-	// 更新工作状态
-	UpdateWorkingStatus(context.Context, *UpdateWorkingStatusRequest) (*emptypb.Empty, error)
-	// 更新权重
-	UpdateWeight(context.Context, *UpdateWeightRequest) (*emptypb.Empty, error)
-	// 更新每日被匹配数
-	UpdateTodayMatchedNum(context.Context, *UpdateTodayMatchedNumRequest) (*emptypb.Empty, error)
-	mustEmbedUnimplementedOnlineServer()
-}
-
-// UnimplementedOnlineServer must be embedded to have forward compatible implementations.
-type UnimplementedOnlineServer struct {
-}
-
-func (UnimplementedOnlineServer) Receive(context.Context, *ReceiveRequest) (*ReceiveReply, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method Receive not implemented")
-}
-func (UnimplementedOnlineServer) SendMsg(context.Context, *SendMsgRequest) (*SendMsgReply, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method SendMsg not implemented")
-}
-func (UnimplementedOnlineServer) CheckIsOnline(context.Context, *CheckIsOnlineRequest) (*CheckIsOnlineReply, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method CheckIsOnline not implemented")
-}
-func (UnimplementedOnlineServer) CheckIsOnlineByIDs(context.Context, *CheckIsOnlineByIDsParam) (*CheckIsOnlineByIDsParam, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method CheckIsOnlineByIDs not implemented")
-}
-func (UnimplementedOnlineServer) FindOnlinePerson(context.Context, *emptypb.Empty) (*OnlinePersonMessageReply, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method FindOnlinePerson not implemented")
-}
-func (UnimplementedOnlineServer) FindOnlineCanMatchingPerson(context.Context, *emptypb.Empty) (*OnlinePersonMessageReply, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method FindOnlineCanMatchingPerson not implemented")
-}
-func (UnimplementedOnlineServer) FindOnlinePersonNum(context.Context, *emptypb.Empty) (*OnlinePersonReply, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method FindOnlinePersonNum not implemented")
-}
-func (UnimplementedOnlineServer) UpdateWorkingStatus(context.Context, *UpdateWorkingStatusRequest) (*emptypb.Empty, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method UpdateWorkingStatus not implemented")
-}
-func (UnimplementedOnlineServer) UpdateWeight(context.Context, *UpdateWeightRequest) (*emptypb.Empty, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method UpdateWeight not implemented")
-}
-func (UnimplementedOnlineServer) UpdateTodayMatchedNum(context.Context, *UpdateTodayMatchedNumRequest) (*emptypb.Empty, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method UpdateTodayMatchedNum not implemented")
-}
-func (UnimplementedOnlineServer) mustEmbedUnimplementedOnlineServer() {}
-
-// UnsafeOnlineServer may be embedded to opt out of forward compatibility for this service.
-// Use of this interface is not recommended, as added methods to OnlineServer will
-// result in compilation errors.
-type UnsafeOnlineServer interface {
-	mustEmbedUnimplementedOnlineServer()
-}
-
-func RegisterOnlineServer(s grpc.ServiceRegistrar, srv OnlineServer) {
-	s.RegisterService(&Online_ServiceDesc, srv)
-}
-
-func _Online_Receive_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(ReceiveRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(OnlineServer).Receive(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/api.online.Online/Receive",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(OnlineServer).Receive(ctx, req.(*ReceiveRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _Online_SendMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(SendMsgRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(OnlineServer).SendMsg(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/api.online.Online/SendMsg",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(OnlineServer).SendMsg(ctx, req.(*SendMsgRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _Online_CheckIsOnline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(CheckIsOnlineRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(OnlineServer).CheckIsOnline(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/api.online.Online/CheckIsOnline",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(OnlineServer).CheckIsOnline(ctx, req.(*CheckIsOnlineRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _Online_CheckIsOnlineByIDs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(CheckIsOnlineByIDsParam)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(OnlineServer).CheckIsOnlineByIDs(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/api.online.Online/CheckIsOnlineByIDs",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(OnlineServer).CheckIsOnlineByIDs(ctx, req.(*CheckIsOnlineByIDsParam))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _Online_FindOnlinePerson_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.(OnlineServer).FindOnlinePerson(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/api.online.Online/FindOnlinePerson",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(OnlineServer).FindOnlinePerson(ctx, req.(*emptypb.Empty))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _Online_FindOnlineCanMatchingPerson_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.(OnlineServer).FindOnlineCanMatchingPerson(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/api.online.Online/FindOnlineCanMatchingPerson",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(OnlineServer).FindOnlineCanMatchingPerson(ctx, req.(*emptypb.Empty))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _Online_FindOnlinePersonNum_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.(OnlineServer).FindOnlinePersonNum(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/api.online.Online/FindOnlinePersonNum",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(OnlineServer).FindOnlinePersonNum(ctx, req.(*emptypb.Empty))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _Online_UpdateWorkingStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(UpdateWorkingStatusRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(OnlineServer).UpdateWorkingStatus(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/api.online.Online/UpdateWorkingStatus",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(OnlineServer).UpdateWorkingStatus(ctx, req.(*UpdateWorkingStatusRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _Online_UpdateWeight_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(UpdateWeightRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(OnlineServer).UpdateWeight(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/api.online.Online/UpdateWeight",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(OnlineServer).UpdateWeight(ctx, req.(*UpdateWeightRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _Online_UpdateTodayMatchedNum_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(UpdateTodayMatchedNumRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(OnlineServer).UpdateTodayMatchedNum(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/api.online.Online/UpdateTodayMatchedNum",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(OnlineServer).UpdateTodayMatchedNum(ctx, req.(*UpdateTodayMatchedNumRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-// Online_ServiceDesc is the grpc.ServiceDesc for Online service.
-// It's only intended for direct use with grpc.RegisterService,
-// and not to be introspected or modified (even as a copy)
-var Online_ServiceDesc = grpc.ServiceDesc{
-	ServiceName: "api.online.Online",
-	HandlerType: (*OnlineServer)(nil),
-	Methods: []grpc.MethodDesc{
-		{
-			MethodName: "Receive",
-			Handler:    _Online_Receive_Handler,
-		},
-		{
-			MethodName: "SendMsg",
-			Handler:    _Online_SendMsg_Handler,
-		},
-		{
-			MethodName: "CheckIsOnline",
-			Handler:    _Online_CheckIsOnline_Handler,
-		},
-		{
-			MethodName: "CheckIsOnlineByIDs",
-			Handler:    _Online_CheckIsOnlineByIDs_Handler,
-		},
-		{
-			MethodName: "FindOnlinePerson",
-			Handler:    _Online_FindOnlinePerson_Handler,
-		},
-		{
-			MethodName: "FindOnlineCanMatchingPerson",
-			Handler:    _Online_FindOnlineCanMatchingPerson_Handler,
-		},
-		{
-			MethodName: "FindOnlinePersonNum",
-			Handler:    _Online_FindOnlinePersonNum_Handler,
-		},
-		{
-			MethodName: "UpdateWorkingStatus",
-			Handler:    _Online_UpdateWorkingStatus_Handler,
-		},
-		{
-			MethodName: "UpdateWeight",
-			Handler:    _Online_UpdateWeight_Handler,
-		},
-		{
-			MethodName: "UpdateTodayMatchedNum",
-			Handler:    _Online_UpdateTodayMatchedNum_Handler,
-		},
-	},
-	Streams:  []grpc.StreamDesc{},
-	Metadata: "online.proto",
-}

+ 0 - 87
api/online/online_http.pb.go

@@ -1,87 +0,0 @@
-// Code generated by protoc-gen-go-http. DO NOT EDIT.
-// versions:
-// protoc-gen-go-http v2.0.0
-
-package online
-
-import (
-	context "context"
-	base "git.ikuban.com/server/base-protobuf/kuban/api/base"
-	reply "git.ikuban.com/server/kratos-utils/http/reply"
-	http "github.com/go-kratos/kratos/v2/transport/http"
-	binding "github.com/go-kratos/kratos/v2/transport/http/binding"
-	ioutil "io/ioutil"
-	time "time"
-)
-
-// This is a compile-time assertion to ensure that this generated file
-// is compatible with the kratos package it is being compiled against.
-var _ = new(context.Context)
-var _ = binding.EncodeURL
-var _ = ioutil.Discard
-var _ = new(time.Time)
-var _ = new(reply.SuccessReply)
-var _ = new(base.Html)
-
-const _ = http.SupportPackageIsVersion1
-
-type OnlineHTTPServer interface {
-	Receive(context.Context, *ReceiveRequest) (*ReceiveReply, error)
-}
-
-func RegisterOnlineHTTPServer(s *http.Server, srv OnlineHTTPServer) {
-	r := s.Route("/")
-	r.POST("/api/online/receive", _Online_Receive0_HTTP_Handler(srv))
-}
-
-func _Online_Receive0_HTTP_Handler(srv OnlineHTTPServer) func(ctx http.Context) error {
-	return func(ctx http.Context) error {
-		var in ReceiveRequest
-		if err := ctx.Bind(&in); err != nil {
-			return err
-		}
-		if err := ctx.BindQuery(&in); err != nil {
-			return err
-		}
-		http.SetOperation(ctx, "/api.online.Online/Receive")
-		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
-			return srv.Receive(ctx, req.(*ReceiveRequest))
-		})
-		out, err := h(ctx, &in)
-		if err != nil {
-			return err
-		}
-		success := &reply.SuccessReply{
-			Code: 0,
-		}
-		if out != nil {
-			success.Data = out
-		}
-		return ctx.Result(200, success)
-	}
-}
-
-type OnlineHTTPClient interface {
-	Receive(ctx context.Context, req *ReceiveRequest, opts ...http.CallOption) (rsp *ReceiveReply, err error)
-}
-
-type OnlineHTTPClientImpl struct {
-	cc *http.Client
-}
-
-func NewOnlineHTTPClient(client *http.Client) OnlineHTTPClient {
-	return &OnlineHTTPClientImpl{client}
-}
-
-func (c *OnlineHTTPClientImpl) Receive(ctx context.Context, in *ReceiveRequest, opts ...http.CallOption) (*ReceiveReply, error) {
-	var out ReceiveReply
-	pattern := "/api/online/receive"
-	path := binding.EncodeURL(pattern, in, false)
-	opts = append(opts, http.Operation("/api.online.Online/Receive"))
-	opts = append(opts, http.PathTemplate(pattern))
-	err := c.cc.Invoke(ctx, "POST", path, in, &out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return &out, err
-}

+ 0 - 13
client/chat.go

@@ -3,7 +3,6 @@ package client
 import (
 	"git.ikuban.com/server/kratos-nacos/registry"
 	"git.ikuban.com/server/pw-protobuf/api/chat"
-	"git.ikuban.com/server/pw-protobuf/api/online"
 	"git.ikuban.com/server/pw-protobuf/api/websocket"
 	"github.com/go-kratos/kratos/v2/log"
 )
@@ -31,15 +30,3 @@ func NewWebsocketClient(r *registry.Registry, logger log.Logger) websocket.Webso
 	client := websocket.NewWebsocketClient(conn)
 	return client
 }
-
-func NewOnlineClient(r *registry.Registry, logger log.Logger) online.OnlineClient {
-	conn, err := getDialInsecure(r, logger, "discovery://pw/pw-online")
-	if err != nil {
-		panic(err)
-	}
-	if conn == nil {
-		return nil
-	}
-	client := online.NewOnlineClient(conn)
-	return client
-}