diff --git a/modules/friend/api_cross_addblack.go b/modules/friend/api_cross_addblack.go index 89d519fb7..f77ec927f 100644 --- a/modules/friend/api_cross_addblack.go +++ b/modules/friend/api_cross_addblack.go @@ -130,6 +130,10 @@ func (this *apiComp) Addblack(session comm.IUserSession, req *pb.FriendAddBlackR UserId: session.GetUserId(), } session.SendMsg(string(this.module.GetType()), FriendSubTypeAddBlack, Resp) - + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.SendMsgToUser(string(this.module.GetType()), "beblackchanage", &pb.FriendBeblackChanagePush{ + Beblackids: target.Beblackids, + }, target.Uid) + }) return } diff --git a/modules/friend/api_cross_delblack.go b/modules/friend/api_cross_delblack.go index 2dab9572a..fcb6789b7 100644 --- a/modules/friend/api_cross_delblack.go +++ b/modules/friend/api_cross_delblack.go @@ -79,5 +79,10 @@ func (this *apiComp) Delblack(session comm.IUserSession, req *pb.FriendDelBlackR } session.SendMsg(string(this.module.GetType()), FriendSubTypeDelBlack, resp) + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.SendMsgToUser(string(this.module.GetType()), "beblackchanage", &pb.FriendBeblackChanagePush{ + Beblackids: target.Beblackids, + }, target.Uid) + }) return } diff --git a/pb/friend_msg.pb.go b/pb/friend_msg.pb.go index 62dfdbf8e..327f0278a 100644 --- a/pb/friend_msg.pb.go +++ b/pb/friend_msg.pb.go @@ -2435,6 +2435,53 @@ func (x *FriendRefreshAssistHeroResp) GetHero() []*AssistHero { return nil } +type FriendBeblackChanagePush struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Beblackids []string `protobuf:"bytes,1,rep,name=beblackids,proto3" json:"beblackids"` +} + +func (x *FriendBeblackChanagePush) Reset() { + *x = FriendBeblackChanagePush{} + if protoimpl.UnsafeEnabled { + mi := &file_friend_friend_msg_proto_msgTypes[48] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *FriendBeblackChanagePush) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*FriendBeblackChanagePush) ProtoMessage() {} + +func (x *FriendBeblackChanagePush) ProtoReflect() protoreflect.Message { + mi := &file_friend_friend_msg_proto_msgTypes[48] + 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 FriendBeblackChanagePush.ProtoReflect.Descriptor instead. +func (*FriendBeblackChanagePush) Descriptor() ([]byte, []int) { + return file_friend_friend_msg_proto_rawDescGZIP(), []int{48} +} + +func (x *FriendBeblackChanagePush) GetBeblackids() []string { + if x != nil { + return x.Beblackids + } + return nil +} + var File_friend_friend_msg_proto protoreflect.FileDescriptor var file_friend_friend_msg_proto_rawDesc = []byte{ @@ -2626,8 +2673,12 @@ var file_friend_friend_msg_proto_rawDesc = []byte{ 0x52, 0x65, 0x66, 0x72, 0x65, 0x73, 0x68, 0x41, 0x73, 0x73, 0x69, 0x73, 0x74, 0x48, 0x65, 0x72, 0x6f, 0x52, 0x65, 0x73, 0x70, 0x12, 0x1f, 0x0a, 0x04, 0x68, 0x65, 0x72, 0x6f, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0b, 0x2e, 0x41, 0x73, 0x73, 0x69, 0x73, 0x74, 0x48, 0x65, 0x72, 0x6f, - 0x52, 0x04, 0x68, 0x65, 0x72, 0x6f, 0x42, 0x06, 0x5a, 0x04, 0x2e, 0x3b, 0x70, 0x62, 0x62, 0x06, - 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, + 0x52, 0x04, 0x68, 0x65, 0x72, 0x6f, 0x22, 0x3a, 0x0a, 0x18, 0x46, 0x72, 0x69, 0x65, 0x6e, 0x64, + 0x42, 0x65, 0x62, 0x6c, 0x61, 0x63, 0x6b, 0x43, 0x68, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x50, 0x75, + 0x73, 0x68, 0x12, 0x1e, 0x0a, 0x0a, 0x62, 0x65, 0x62, 0x6c, 0x61, 0x63, 0x6b, 0x69, 0x64, 0x73, + 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0a, 0x62, 0x65, 0x62, 0x6c, 0x61, 0x63, 0x6b, 0x69, + 0x64, 0x73, 0x42, 0x06, 0x5a, 0x04, 0x2e, 0x3b, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, + 0x6f, 0x33, } var ( @@ -2642,7 +2693,7 @@ func file_friend_friend_msg_proto_rawDescGZIP() []byte { return file_friend_friend_msg_proto_rawDescData } -var file_friend_friend_msg_proto_msgTypes = make([]protoimpl.MessageInfo, 48) +var file_friend_friend_msg_proto_msgTypes = make([]protoimpl.MessageInfo, 49) var file_friend_friend_msg_proto_goTypes = []interface{}{ (*FriendBase)(nil), // 0: FriendBase (*FriendListReq)(nil), // 1: FriendListReq @@ -2692,28 +2743,29 @@ var file_friend_friend_msg_proto_goTypes = []interface{}{ (*FriendZanAndReceiveResp)(nil), // 45: FriendZanAndReceiveResp (*FriendRefreshAssistHeroReq)(nil), // 46: FriendRefreshAssistHeroReq (*FriendRefreshAssistHeroResp)(nil), // 47: FriendRefreshAssistHeroResp - (*DBFriend)(nil), // 48: DBFriend - (*AssistRecord)(nil), // 49: AssistRecord - (*UserAtno)(nil), // 50: UserAtno - (*AssistHero)(nil), // 51: AssistHero + (*FriendBeblackChanagePush)(nil), // 48: FriendBeblackChanagePush + (*DBFriend)(nil), // 49: DBFriend + (*AssistRecord)(nil), // 50: AssistRecord + (*UserAtno)(nil), // 51: UserAtno + (*AssistHero)(nil), // 52: AssistHero } var file_friend_friend_msg_proto_depIdxs = []int32{ 0, // 0: FriendListResp.list:type_name -> FriendBase - 48, // 1: FriendListResp.friend:type_name -> DBFriend + 49, // 1: FriendListResp.friend:type_name -> DBFriend 0, // 2: FriendRandlistResp.list:type_name -> FriendBase 0, // 3: FriendApplyListResp.list:type_name -> FriendBase 0, // 4: FriendSearchResp.friends:type_name -> FriendBase 0, // 5: FriendBlackListResp.friends:type_name -> FriendBase 0, // 6: FriendZanlistResp.list:type_name -> FriendBase 0, // 7: FriendAssistlistResp.list:type_name -> FriendBase - 49, // 8: FriendAssistlistResp.record:type_name -> AssistRecord - 50, // 9: FriendGetrewardResp.atno:type_name -> UserAtno + 50, // 8: FriendAssistlistResp.record:type_name -> AssistRecord + 51, // 9: FriendGetrewardResp.atno:type_name -> UserAtno 0, // 10: FriendAssistHeroUpdatePush.friend:type_name -> FriendBase 0, // 11: FriendAssistHeroListResp.friends:type_name -> FriendBase 0, // 12: FriendAddAgreePush.info:type_name -> FriendBase 0, // 13: FriendAddApplyPush.info:type_name -> FriendBase - 50, // 14: FriendZanAndReceiveResp.atno:type_name -> UserAtno - 51, // 15: FriendRefreshAssistHeroResp.hero:type_name -> AssistHero + 51, // 14: FriendZanAndReceiveResp.atno:type_name -> UserAtno + 52, // 15: FriendRefreshAssistHeroResp.hero:type_name -> AssistHero 16, // [16:16] is the sub-list for method output_type 16, // [16:16] is the sub-list for method input_type 16, // [16:16] is the sub-list for extension type_name @@ -3305,6 +3357,18 @@ func file_friend_friend_msg_proto_init() { return nil } } + file_friend_friend_msg_proto_msgTypes[48].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*FriendBeblackChanagePush); 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{ @@ -3312,7 +3376,7 @@ func file_friend_friend_msg_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_friend_friend_msg_proto_rawDesc, NumEnums: 0, - NumMessages: 48, + NumMessages: 49, NumExtensions: 0, NumServices: 0, },