StarEscort/DotNet/Hotfix/Scenes/Game/Handler/R2G_LiveGiftHandler.cs

using System;
using System.Linq;
using System.Numerics;
using System.Text;
using System.Text.Json;

namespace ET.Server
{
    /// <summary>
    /// 抖音推送回调, 送礼物
    /// </summary>
    [ActorMessageHandler(SceneType.Game)]
    public class R2G_LiveGiftHandler: AMActorHandler<Scene, R2G_LiveGift>
    {
        protected override async ETTask Run(Scene scene, R2G_LiveGift request)
        {
            // 房间是否存在
            Map map = scene.GetComponent<GameMapComponent>().GetMapByRoomId(request.RoomId);

            if (map == null)
            {
                Log.Error($"未找到房间...roomId={request.RoomId}");
                return;
            }

            Struct.UnitPlayerData unitPlayerData = map.GetUnitPlayerByOpenId(request.OpenId);
            // 数据是否存在
            if (unitPlayerData == null)
            {
                Log.Error($"未找到单位玩家数据...openId={request.OpenId}");
                return;
            }

            unitPlayerData.GiftMoney += (int)request.GiftValue;

            // 推送客户端
            if (map.Player != null)
            {
                MessageHelper.SendToClient(map.Player, new G2C_GiftInfoPush { NickName = request.NickName, GiftType = DouyinItem.GiftHash[request.GiftId],
                    GiftNum = (int)request.GiftNum, Url = request.Url, TotalMoney = unitPlayerData.GiftMoney, UnitId = unitPlayerData.ObjId});
            }

            Struct.TriggerEventNotify notify = null;

            if (DouyinItem.GiftId_1.Equals(request.GiftId) || DouyinItem.GiftId_10.Equals(request.GiftId))
            {
                // 仙女棒 自己死了复活自己, 自己没死复活其他人, 不够则补充单位
                // 能量药丸 自己死了复活自己, 自己没死复活其他3个人, 不够则补充单位

                StringBuilder objIds = new StringBuilder();

                notify = new Struct.TriggerEventNotify();

                if (unitPlayerData.DeadState == 1)
                {
                    objIds.Append(unitPlayerData.ObjId);
                }
                else
                {
                    long cnt = request.GiftNum * (DouyinItem.GiftId_1.Equals(request.GiftId)? 1 : 3);

                    foreach (int objId in map.DeadUnitPlayer)
                    {
                        if (objId > 0)
                        {
                            objIds.Append(objId).Append(',');
                            cnt -= 1;
                        }
                        if (cnt <= 0)
                        {
                            break;
                        }
                    }

                    if (cnt > 0)
                    {
                        // 补充单位
                        for (int i = 0; i < cnt; i++)
                        {
                            // 临时openId
                            string _openId = (10000 + new Random().Next(999)).ToString();
                            Vector2 pos = map.GetRandomPlayerPos();
                            string name = map.GetRandomPlayerName();
                            await map.AddUnitPlayer(_openId, 0, 1, "", pos.X, pos.Y, name, "");
                        }
                    }
                }

                notify.message = DouyinItem.GiftId_1.Equals(request.GiftId)? BattleNotify.TiktokGift_1.ToString() : BattleNotify.TiktokGift_10.ToString();
                notify.TriggerUnits = objIds.ToString();
                map.GetXmdsManager().notifyBattleServer(map.Id.ToString(), NotifyBSName.TriggerEvent, JsonSerializer.Serialize(notify));

                // Log.Debug($"============================================仙女棒/能量药丸 notifyBattleServer - data={JsonSerializer.Serialize(notify)}");
            }
            else
            {
                for (int i = 0; i < request.GiftNum; i++)
                {
                    switch (request.GiftId)
                    {
                        case DouyinItem.GiftId_52:
                            // 甜甜圈
                            const long maxLevel = 3; // 等级上限
                            notify = new Struct.TriggerEventNotify();
                            if (unitPlayerData.Level < maxLevel)
                            {
                                ++unitPlayerData.Level;
                                notify.message = BattleNotify.TiktokGift_52.ToString();
                            }
                            else
                            {
                                notify.message = BattleNotify.TiktokGift_52_ext.ToString();
                            }
                            notify.TriggerUnits = unitPlayerData.ObjId.ToString();
                            break;
                        case DouyinItem.GiftId_99:
                            // 能量电池
                            notify = new Struct.TriggerEventNotify();
                            notify.message = BattleNotify.TiktokGift_99.ToString();
                            notify.TriggerUnits = unitPlayerData.ObjId.ToString();
                            // 对应的贡献值
                            map.AddContributeValue(request.OpenId, 99);
                            break;
                        case DouyinItem.GiftId_199:
                            // 恶魔炸弹
                            notify = new Struct.TriggerEventNotify();
                            notify.message = BattleNotify.TiktokGift_199.ToString();
                            notify.TriggerUnits = unitPlayerData.ObjId.ToString();
                            // 对应的贡献值
                            map.AddContributeValue(request.OpenId, 199);
                            break;
                        case DouyinItem.GiftId_520:
                            // 神秘空投
                            notify = new Struct.TriggerEventNotify();
                            notify.message = BattleNotify.TiktokGift_520.ToString();
                            notify.TriggerUnits = unitPlayerData.ObjId.ToString();
                            // 对应的贡献值
                            map.AddContributeValue(request.OpenId, 520);
                            break;
                    }

                    map.GetXmdsManager().notifyBattleServer(map.Id.ToString(), NotifyBSName.TriggerEvent, JsonSerializer.Serialize(notify));
                    //间隔30ms，触发一次礼物效果
                    await TimerComponent.Instance.WaitAsync(30);
                }
            }
        }
    }
}