From d3e60c5aafccd78a0687bdb2aba38932e39a8e03 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B0=8F=E7=99=BD=E7=8C=BF?= <1083092844@qq.com> Date: Sat, 1 Apr 2023 00:07:17 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BC=B9=E5=B9=95=E6=B7=BB=E5=8A=A0=20?= =?UTF-8?q?=E5=AE=98=E6=96=B9MsgId?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- BarrageGrab/JsonEntity/BarrageMessages.cs | 5 +++++ BarrageGrab/ProtoEntity/Messages.cs | 2 +- BarrageGrab/WsBarrageService.cs | 26 ++++++++++++++++------- 3 files changed, 24 insertions(+), 9 deletions(-) diff --git a/BarrageGrab/JsonEntity/BarrageMessages.cs b/BarrageGrab/JsonEntity/BarrageMessages.cs index c3b440d..16b3691 100644 --- a/BarrageGrab/JsonEntity/BarrageMessages.cs +++ b/BarrageGrab/JsonEntity/BarrageMessages.cs @@ -57,6 +57,11 @@ /// public class Msg { + /// + /// 弹幕ID + /// + public long MsgId { get; set; } + /// /// 用户数据 /// diff --git a/BarrageGrab/ProtoEntity/Messages.cs b/BarrageGrab/ProtoEntity/Messages.cs index af3bf1d..5a2c69d 100644 --- a/BarrageGrab/ProtoEntity/Messages.cs +++ b/BarrageGrab/ProtoEntity/Messages.cs @@ -554,7 +554,7 @@ namespace BarrageGrab.ProtoEntity => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing); [global::ProtoBuf.ProtoMember(1)] - public Common commonInfo { get; set; } + public Common Common { get; set; } /// /// 升级1 加入2 diff --git a/BarrageGrab/WsBarrageService.cs b/BarrageGrab/WsBarrageService.cs index 944e557..7ff5a25 100644 --- a/BarrageGrab/WsBarrageService.cs +++ b/BarrageGrab/WsBarrageService.cs @@ -69,13 +69,16 @@ namespace BarrageGrab HeadImgUrl = data.avatarThumb.urlLists.FirstOrDefault()??"", SecUid = data.sec_uid }; - if (data.fansClub.Data != null) + user.FansClub = new FansClubInfo() { - user.FansClub = new FansClubInfo() - { - ClubName = data.fansClub.Data.clubName, - Level = data.fansClub.Data.Level - }; + ClubName = "", + Level = 0 + }; + + if (data.fansClub!= null && data.fansClub.Data != null) + { + user.FansClub.ClubName = data.fansClub.Data.clubName; + user.Level = data.fansClub.Data.Level; } return user; @@ -84,11 +87,12 @@ namespace BarrageGrab //粉丝团 private void Grab_OnFansclubMessage(object sender, ProtoEntity.FansclubMessage e) { - if (!CheckRoomId(e.commonInfo.roomId)) return; + if (!CheckRoomId(e.Common.roomId)) return; var enty = new FansclubMsg() { + MsgId = e.Common.msgId, Content = e.Content, - RoomId = e.commonInfo.roomId, + RoomId = e.Common.roomId, Type = e.Type, User = GetUser(e.User) }; @@ -104,6 +108,7 @@ namespace BarrageGrab if (!CheckRoomId(e.Common.roomId)) return; var enty = new UserSeqMsg() { + MsgId = e.Common.msgId, OnlineUserCount = e.Total, TotalUserCount = e.totalUser, TotalUserCountStr = e.totalPvForAnchor, @@ -125,6 +130,7 @@ namespace BarrageGrab var enty = new GiftMsg() { + MsgId = e.Common.msgId, RoomId = e.Common.roomId, Content = e.Common.Describe, DiamondCount = e.Gift.diamondCount, @@ -148,6 +154,7 @@ namespace BarrageGrab var enty = new Msg() { + MsgId = e.Common.msgId, Content = $"{e.User.Nickname} 关注了主播", RoomId = e.Common.roomId, User = GetUser(e.User) @@ -165,6 +172,7 @@ namespace BarrageGrab var enty = new JsonEntity.MemberMessage() { + MsgId = e.Common.msgId, Content = $"{e.User.Nickname} 来了 直播间人数:{e.memberCount}", RoomId = e.Common.roomId, CurrentCount = e.memberCount, @@ -183,6 +191,7 @@ namespace BarrageGrab var enty = new LikeMsg() { + MsgId = e.Common.msgId, Count = e.Count, Content = $"{e.User.Nickname} 为主播点了{e.Count}个赞,总点赞{e.Total}", RoomId = e.Common.roomId, @@ -202,6 +211,7 @@ namespace BarrageGrab var enty = new Msg() { + MsgId = e.Common.msgId, Content = e.Content, RoomId = e.Common.roomId, User = GetUser(e.User)