using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.IO.Pipes;
using System.Linq;
using System.Net.WebSockets;
using System.Reflection;
using System.Runtime.CompilerServices;
using System.Runtime.Versioning;
using System.Security;
using System.Security.Permissions;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using BepInEx;
using BepInEx.Configuration;
using Microsoft.CodeAnalysis;
using Newtonsoft.Json;
using UnityEngine;

[assembly: CompilationRelaxations(8)]
[assembly: RuntimeCompatibility(WrapNonExceptionThrows = true)]
[assembly: Debuggable(DebuggableAttribute.DebuggingModes.Default | DebuggableAttribute.DebuggingModes.DisableOptimizations | DebuggableAttribute.DebuggingModes.IgnoreSymbolStoreSequencePoints | DebuggableAttribute.DebuggingModes.EnableEditAndContinue)]
[assembly: TargetFramework(".NETFramework,Version=v4.8.1", FrameworkDisplayName = "")]
[assembly: AssemblyCompany("DspZhibo.Mod")]
[assembly: AssemblyConfiguration("Debug")]
[assembly: AssemblyFileVersion("1.0.0.0")]
[assembly: AssemblyInformationalVersion("1.0.0+3d630be82154e82087bfee4c350a39549076d773")]
[assembly: AssemblyProduct("DspZhibo.Mod")]
[assembly: AssemblyTitle("DspZhibo.Mod")]
[assembly: SecurityPermission(SecurityAction.RequestMinimum, SkipVerification = true)]
[assembly: AssemblyVersion("1.0.0.0")]
[module: UnverifiableCode]
[module: RefSafetyRules(11)]
namespace Microsoft.CodeAnalysis
{
	[CompilerGenerated]
	[Microsoft.CodeAnalysis.Embedded]
	internal sealed class EmbeddedAttribute : Attribute
	{
	}
}
namespace System.Runtime.CompilerServices
{
	[CompilerGenerated]
	[Microsoft.CodeAnalysis.Embedded]
	[AttributeUsage(AttributeTargets.Class | AttributeTargets.Property | AttributeTargets.Field | AttributeTargets.Event | AttributeTargets.Parameter | AttributeTargets.ReturnValue | AttributeTargets.GenericParameter, AllowMultiple = false, Inherited = false)]
	internal sealed class NullableAttribute : Attribute
	{
		public readonly byte[] NullableFlags;

		public NullableAttribute(byte P_0)
		{
			NullableFlags = new byte[1] { P_0 };
		}

		public NullableAttribute(byte[] P_0)
		{
			NullableFlags = P_0;
		}
	}
	[CompilerGenerated]
	[Microsoft.CodeAnalysis.Embedded]
	[AttributeUsage(AttributeTargets.Module, AllowMultiple = false, Inherited = false)]
	internal sealed class RefSafetyRulesAttribute : Attribute
	{
		public readonly int Version;

		public RefSafetyRulesAttribute(int P_0)
		{
			Version = P_0;
		}
	}
}
namespace DspZhibo.Mod
{
	public class BattleManager
	{
		private PunishmentConfig _config;

		public BattleManager()
		{
			_config = PunishmentConfig.Load();
		}

		public void TriggerPunishment(string ticketName)
		{
			try
			{
				float punishmentChance = GetPunishmentChance(ticketName);
				if (punishmentChance <= 0f)
				{
					Debug.Log((object)("[" + ticketName + "] 不会触发黑雾惩罚"));
					return;
				}
				float value = Random.value;
				if (value > punishmentChance)
				{
					Debug.Log((object)("[" + ticketName + "] 幸运逃过一劫！本次不触发惩罚"));
					return;
				}
				Debug.Log((object)("[黑雾] " + ticketName + " 触发惩罚！"));
				DFSystemManager.IncreaseThreat(ticketName);
				if (_config.immediateSpawn)
				{
					StarData localStar = GameMain.data.localStar;
					if (localStar != null)
					{
						int enemyCount = _config.GetEnemyCount();
						DFSystemManager.SpawnEnemies(localStar.id, -1, enemyCount);
					}
				}
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("触发惩罚失败: " + ex.Message + "\n" + ex.StackTrace));
			}
		}

		private float GetPunishmentChance(string ticketName)
		{
			if (ticketName.Contains("普通"))
			{
				return 0.5f;
			}
			if (ticketName.Contains("稀有"))
			{
				return 0.1f;
			}
			if (ticketName.Contains("VIP"))
			{
				return 0f;
			}
			return _config.ShouldTriggerPunishment() ? _config.spawnChance : 0f;
		}

		public void ReloadConfig()
		{
			_config = PunishmentConfig.Load();
			Debug.Log((object)"惩罚配置已重新加载");
		}

		public PunishmentConfig GetConfig()
		{
			return _config;
		}

		public string GetThreatInfo()
		{
			return DFSystemManager.GetThreatInfo();
		}

		public void ManualTrigger()
		{
			Debug.Log((object)"[黑雾] 手动触发惩罚");
			TriggerPunishment("手动触发");
		}
	}
	public class Config
	{
		public ConfigEntry<bool> EnableUI { get; }

		public ConfigEntry<string> PipeName { get; }

		public ConfigEntry<int> UIPositionX { get; }

		public ConfigEntry<int> UIPositionY { get; }

		public Config(ConfigFile config)
		{
			EnableUI = config.Bind<bool>("General", "EnableUI", true, "是否启用游戏内UI");
			PipeName = config.Bind<string>("Network", "PipeName", "DspZhiboPipe", "命名管道名称");
			UIPositionX = config.Bind<int>("UI", "PositionX", 20, "UI窗口X位置");
			UIPositionY = config.Bind<int>("UI", "PositionY", 20, "UI窗口Y位置");
		}
	}
	public class DFSystemManager
	{
		public static void IncreaseThreat(string ticketName)
		{
			try
			{
				if (GameMain.data == null || GameMain.data.mainPlayer == null)
				{
					Debug.LogWarning((object)"[黑雾] 无法获取玩家数据");
					return;
				}
				StarData localStar = GameMain.data.localStar;
				if (localStar == null)
				{
					Debug.LogWarning((object)"[黑雾] 无法获取当前星区");
					return;
				}
				int num = CalculateThreatIncrease(ticketName);
				if (TryIncreaseThreat(localStar.id, num))
				{
					int num2 = (int)Math.Ceiling((double)num / 10.0);
					int num3 = num2 * 3;
					Debug.Log((object)$"[黑雾] 星区 {localStar.displayName} ({localStar.id}) 威胁度增加 +{num}");
					Debug.Log((object)$"[黑雾] 预计生成约 {num2} 波、共 {num3} 个敌人");
					UIRealtimeTip.Popup($"⚠\ufe0f 黑雾来袭！星区 {localStar.displayName} 威胁度上升！\n预计生成 {num2} 波敌人", true, 0);
				}
				else
				{
					Debug.LogWarning((object)"[黑雾] 无法直接增加威胁度，将模拟敌人通知");
					int num4 = (int)Math.Ceiling((double)num / 10.0);
					UIRealtimeTip.Popup($"⚠\ufe0f 黑雾来袭！星区 {localStar.displayName}\n预计 {num4} 波敌人正在接近！", true, 0);
				}
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("[黑雾] 增加威胁度失败: " + ex.Message + "\n" + ex.StackTrace));
			}
		}

		private static bool TryIncreaseThreat(int starId, int threatIncrease)
		{
			try
			{
				GameData data = GameMain.data;
				if (data == null)
				{
					Debug.LogWarning((object)"[黑雾] GameMain.data为空");
					return false;
				}
				FieldInfo fieldInfo = ((object)data).GetType().GetFields().FirstOrDefault((FieldInfo f) => f.FieldType.Name.Contains("DF") || f.FieldType.Name.Contains("DomainF"));
				if (fieldInfo != null)
				{
					object value = fieldInfo.GetValue(data);
					if (value != null)
					{
						Debug.Log((object)("[黑雾] 找到DFSystem字段: " + fieldInfo.Name + ", 类型: " + value.GetType().Name));
						MethodInfo method = value.GetType().GetMethod("SetDanger", BindingFlags.Instance | BindingFlags.Public | BindingFlags.NonPublic);
						if (method != null)
						{
							method.Invoke(value, new object[2]
							{
								(ulong)starId,
								threatIncrease
							});
							Debug.Log((object)$"[黑雾] 通过SetDanger设置星区 {starId} 威胁度 +{threatIncrease}");
							return true;
						}
						MethodInfo method2 = value.GetType().GetMethod("AddDanger", BindingFlags.Instance | BindingFlags.Public | BindingFlags.NonPublic);
						if (method2 != null)
						{
							method2.Invoke(value, new object[2]
							{
								(ulong)starId,
								threatIncrease
							});
							Debug.Log((object)$"[黑雾] 通过AddDanger增加星区 {starId} 威胁度 {threatIncrease}");
							return true;
						}
						FieldInfo fieldInfo2 = value.GetType().GetFields().FirstOrDefault((FieldInfo f) => f.Name.Contains("danger") || f.Name.Contains("Danger"));
						if (fieldInfo2 != null)
						{
							object value2 = fieldInfo2.GetValue(value);
							if (value2 != null)
							{
								PropertyInfo propertyInfo = value2.GetType().GetProperties().FirstOrDefault((PropertyInfo p) => p.GetIndexParameters().Length == 1 && (p.GetIndexParameters()[0].ParameterType == typeof(int) || p.GetIndexParameters()[0].ParameterType == typeof(uint) || p.GetIndexParameters()[0].ParameterType == typeof(ulong)));
								if (propertyInfo != null)
								{
									object value3 = propertyInfo.GetValue(value2, new object[1] { starId });
									int num = ((value3 != null) ? Convert.ToInt32(value3) : 0) + threatIncrease;
									propertyInfo.SetValue(value2, new object[2] { starId, num });
									Debug.Log((object)$"[黑雾] 通过索引器设置星区 {starId} 威胁度 {num}");
									return true;
								}
							}
						}
					}
				}
				Assembly[] assemblies = AppDomain.CurrentDomain.GetAssemblies();
				Assembly[] array = assemblies;
				foreach (Assembly assembly in array)
				{
					if (assembly == null)
					{
						continue;
					}
					Type dfSystemType = assembly.GetTypes().FirstOrDefault((Type t) => t.Name.Contains("DFSystem") || t.Name.Contains("DomainF") || t.Name.EndsWith("DF"));
					if (!(dfSystemType != null))
					{
						continue;
					}
					Debug.Log((object)("[黑雾] 在程序集中找到DFSystem类型: " + dfSystemType.FullName));
					FieldInfo fieldInfo3 = ((object)data).GetType().GetFields().FirstOrDefault((FieldInfo f) => f.FieldType == dfSystemType);
					if (!(fieldInfo3 != null))
					{
						continue;
					}
					object value4 = fieldInfo3.GetValue(data);
					if (value4 != null)
					{
						MethodInfo method3 = value4.GetType().GetMethod("SetDanger", BindingFlags.Instance | BindingFlags.Public | BindingFlags.NonPublic);
						if (method3 != null)
						{
							method3.Invoke(value4, new object[2]
							{
								(ulong)starId,
								threatIncrease
							});
							Debug.Log((object)$"[黑雾] 通过SetDanger设置星区 {starId} 威胁度 +{threatIncrease}");
							return true;
						}
					}
				}
				Debug.LogWarning((object)"[黑雾] 所有增加威胁度的方法都失败了");
				return false;
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("[黑雾] TryIncreaseThreat失败: " + ex.Message));
				return false;
			}
		}

		private static int CalculateThreatIncrease(string ticketName)
		{
			if (ticketName.Contains("普通"))
			{
				return 20;
			}
			if (ticketName.Contains("稀有"))
			{
				return 10;
			}
			if (ticketName.Contains("VIP"))
			{
				return 0;
			}
			return 10;
		}

		public static void SpawnEnemies(int starId, int planetId = -1, int enemyCount = 1)
		{
			//IL_0141: Unknown result type (might be due to invalid IL or missing references)
			try
			{
				if (GameMain.data == null)
				{
					return;
				}
				if (planetId < 0)
				{
					PlanetData localPlanet = GameMain.data.localPlanet;
					if (localPlanet != null)
					{
						planetId = localPlanet.id;
					}
				}
				Assembly[] assemblies = AppDomain.CurrentDomain.GetAssemblies();
				bool flag = false;
				Assembly[] array = assemblies;
				Vector3 val = default(Vector3);
				foreach (Assembly assembly in array)
				{
					if (flag)
					{
						break;
					}
					List<Type> list = (from t in assembly.GetTypes()
						where t.Name.Contains("Enemy") || t.Name.Contains("Battle") || t.Name.Contains("DF")
						select t).ToList();
					foreach (Type item in list)
					{
						MethodInfo[] methods = item.GetMethods(BindingFlags.Static | BindingFlags.Public);
						MethodInfo methodInfo = methods.FirstOrDefault((MethodInfo m) => (m.Name.Contains("Spawn") && m.GetParameters().Length >= 2 && m.GetParameters()[0].ParameterType == typeof(int)) || m.GetParameters()[0].ParameterType == typeof(uint));
						if (!(methodInfo != null))
						{
							continue;
						}
						try
						{
							((Vector3)(ref val))..ctor(Random.Range(-100f, 100f), 0f, Random.Range(-100f, 100f));
							for (int j = 0; j < enemyCount; j++)
							{
								methodInfo.Invoke(null, new object[2] { starId, val });
								Debug.Log((object)$"[黑雾] 在星区 {starId} 生成敌人 #{j + 1}");
							}
							flag = true;
						}
						catch (Exception ex)
						{
							Debug.LogError((object)("[黑雾] 调用" + item.Name + "." + methodInfo.Name + "失败: " + ex.Message));
							continue;
						}
						break;
					}
					if (flag)
					{
						break;
					}
				}
				if (!flag)
				{
					Debug.LogWarning((object)"[黑雾] 未找到生成敌人的方法，只能通过威胁度系统生成敌人");
				}
			}
			catch (Exception ex2)
			{
				Debug.LogError((object)("[黑雾] 生成敌人失败: " + ex2.Message + "\n" + ex2.StackTrace));
			}
		}

		public static string GetThreatInfo()
		{
			try
			{
				if (GameMain.data == null)
				{
					return "游戏数据未加载";
				}
				StarData localStar = GameMain.data.localStar;
				if (localStar == null)
				{
					return "未在星区中";
				}
				int num = 0;
				FieldInfo fieldInfo = ((object)GameMain.data).GetType().GetFields().FirstOrDefault((FieldInfo f) => f.FieldType.Name.Contains("DF") || f.Name.Contains("DomainF"));
				if (fieldInfo != null)
				{
					object value = fieldInfo.GetValue(GameMain.data);
					if (value != null)
					{
						FieldInfo fieldInfo2 = value.GetType().GetFields().FirstOrDefault((FieldInfo f) => f.Name.Contains("danger") || f.Name.Contains("Danger"));
						if (fieldInfo2 != null)
						{
							object value2 = fieldInfo2.GetValue(value);
							if (value2 != null)
							{
								PropertyInfo propertyInfo = value2.GetType().GetProperties().FirstOrDefault((PropertyInfo p) => p.GetIndexParameters().Length == 1 && (p.GetIndexParameters()[0].ParameterType == typeof(int) || p.GetIndexParameters()[0].ParameterType == typeof(uint) || p.GetIndexParameters()[0].ParameterType == typeof(ulong)));
								if (propertyInfo != null)
								{
									object value3 = propertyInfo.GetValue(value2, new object[1] { localStar.id });
									if (value3 != null)
									{
										num = Convert.ToInt32(value3);
									}
								}
							}
						}
					}
				}
				int num2 = (int)Math.Ceiling((double)num / 10.0);
				return string.Format("星区: {0}\n当前威胁度: {1}\n状态: {2}", localStar.displayName, num, (num > 0) ? $"有黑雾活动 ({num2} 波敌人)" : "安全");
			}
			catch (Exception ex)
			{
				return "获取威胁度信息失败: " + ex.Message;
			}
		}

		public static int GetThreatValue()
		{
			try
			{
				if (GameMain.data == null)
				{
					return 0;
				}
				StarData localStar = GameMain.data.localStar;
				if (localStar == null)
				{
					return 0;
				}
				int result = 0;
				FieldInfo fieldInfo = ((object)GameMain.data).GetType().GetFields().FirstOrDefault((FieldInfo f) => f.FieldType.Name.Contains("DF") || f.Name.Contains("DomainF"));
				if (fieldInfo != null)
				{
					object value = fieldInfo.GetValue(GameMain.data);
					if (value != null)
					{
						FieldInfo fieldInfo2 = value.GetType().GetFields().FirstOrDefault((FieldInfo f) => f.Name.Contains("danger") || f.Name.Contains("Danger"));
						if (fieldInfo2 != null)
						{
							object value2 = fieldInfo2.GetValue(value);
							if (value2 != null)
							{
								PropertyInfo propertyInfo = value2.GetType().GetProperties().FirstOrDefault((PropertyInfo p) => p.GetIndexParameters().Length == 1 && (p.GetIndexParameters()[0].ParameterType == typeof(int) || p.GetIndexParameters()[0].ParameterType == typeof(uint) || p.GetIndexParameters()[0].ParameterType == typeof(ulong)));
								if (propertyInfo != null)
								{
									object value3 = propertyInfo.GetValue(value2, new object[1] { localStar.id });
									if (value3 != null)
									{
										result = Convert.ToInt32(value3);
									}
								}
							}
						}
					}
				}
				return result;
			}
			catch
			{
				return 0;
			}
		}
	}
	public class GiftConfig
	{
		public bool enabled = true;

		public Dictionary<string, GiftReward> giftRewards = new Dictionary<string, GiftReward>();

		private static string _configPath => Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData), "DspZhibo", "GiftConfig.json");

		public static GiftConfig Load()
		{
			GiftConfig giftConfig = new GiftConfig();
			try
			{
				string directoryName = Path.GetDirectoryName(_configPath);
				if (!Directory.Exists(directoryName))
				{
					Directory.CreateDirectory(directoryName);
				}
				if (File.Exists(_configPath))
				{
					string text = File.ReadAllText(_configPath);
					giftConfig = JsonConvert.DeserializeObject<GiftConfig>(text);
					Debug.Log((object)$"[GiftConfig] 从文件加载配置，giftRewards.Count = {giftConfig.giftRewards?.Count ?? 0}");
				}
				else
				{
					Debug.Log((object)"[GiftConfig] 文件不存在，创建默认配置");
					giftConfig = GetDefaultConfig();
					giftConfig.Save();
					Debug.Log((object)$"[GiftConfig] 默认配置已保存，giftRewards.Count = {giftConfig.giftRewards?.Count ?? 0}");
				}
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("加载礼物配置失败: " + ex.Message + "\n" + ex.StackTrace));
				giftConfig = GetDefaultConfig();
			}
			Debug.Log((object)$"[GiftConfig] 返回配置，giftRewards.Count = {giftConfig.giftRewards?.Count ?? 0}");
			return giftConfig;
		}

		public void Save()
		{
			try
			{
				string directoryName = Path.GetDirectoryName(_configPath);
				if (!Directory.Exists(directoryName))
				{
					Directory.CreateDirectory(directoryName);
				}
				string contents = JsonConvert.SerializeObject((object)this, (Formatting)1);
				File.WriteAllText(_configPath, contents);
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("保存礼物配置失败: " + ex.Message));
			}
		}

		private static GiftConfig GetDefaultConfig()
		{
			GiftConfig giftConfig = new GiftConfig();
			giftConfig.enabled = true;
			giftConfig.giftRewards = new Dictionary<string, GiftReward>
			{
				["VIP奖券"] = new GiftReward
				{
					enabled = true,
					ticketName = "VIP奖券",
					ticketCount = 1,
					message = "感谢您的支持！赠送您额外奖励：",
					rewards = new ItemReward[3]
					{
						new ItemReward
						{
							itemId = 1001,
							itemName = "磁铁矿",
							count = 50
						},
						new ItemReward
						{
							itemId = 1002,
							itemName = "煤矿",
							count = 50
						},
						new ItemReward
						{
							itemId = 1003,
							itemName = "铜矿",
							count = 50
						}
					}
				},
				["稀有奖券"] = new GiftReward
				{
					enabled = true,
					ticketName = "稀有奖券",
					ticketCount = 1,
					message = "稀有奖励已发放！",
					rewards = new ItemReward[2]
					{
						new ItemReward
						{
							itemId = 1101,
							itemName = "磁铁",
							count = 20
						},
						new ItemReward
						{
							itemId = 1103,
							itemName = "铜块",
							count = 20
						}
					}
				},
				["普通奖券"] = new GiftReward
				{
					enabled = true,
					ticketName = "普通奖券",
					ticketCount = 1,
					message = "感谢使用！",
					rewards = new ItemReward[1]
					{
						new ItemReward
						{
							itemId = 1001,
							itemName = "磁铁矿",
							count = 10
						}
					}
				}
			};
			return giftConfig;
		}

		public GiftReward GetReward(string ticketName)
		{
			if (!enabled)
			{
				return null;
			}
			foreach (string key in giftRewards.Keys)
			{
				if (ticketName.Contains(key))
				{
					GiftReward giftReward = giftRewards[key];
					return giftReward.enabled ? giftReward : null;
				}
			}
			return null;
		}
	}
	[Serializable]
	public class GiftReward
	{
		public bool enabled = true;

		public string message = "";

		public string ticketName = "";

		public int ticketCount = 1;

		public ItemReward[] rewards = new ItemReward[0];
	}
	[Serializable]
	public class ItemReward
	{
		public int itemId;

		public string itemName;

		public int count;
	}
	internal static class MyPluginInfo
	{
		public const string PLUGIN_GUID = "com.dspzhibo.mod";

		public const string PLUGIN_NAME = "DspZhibo Mod";

		public const string PLUGIN_VERSION = "1.1.0";
	}
	public class NamedPipeServer
	{
		private readonly string _pipeName;

		private NamedPipeServerStream? _pipeServer;

		private Thread? _listenThread;

		private bool _isRunning;

		private readonly Queue<Action> _mainThreadActions = new Queue<Action>();

		private readonly object _lockObject = new object();

		private GiftConfig _giftConfig;

		private BattleManager _battleManager;

		public NamedPipeServer(string pipeName)
		{
			_pipeName = pipeName;
			_giftConfig = GiftConfig.Load();
			_battleManager = new BattleManager();
		}

		public void Start()
		{
			_isRunning = true;
			_listenThread = new Thread(ListenForClients)
			{
				IsBackground = true
			};
			_listenThread.Start();
		}

		private void ListenForClients()
		{
			while (_isRunning)
			{
				try
				{
					using (_pipeServer = new NamedPipeServerStream(_pipeName, PipeDirection.In, 1, PipeTransmissionMode.Message, PipeOptions.Asynchronous))
					{
						Debug.Log((object)"等待客户端连接...");
						_pipeServer.WaitForConnection();
						Debug.Log((object)"客户端已连接!");
						StreamReader streamReader = new StreamReader(_pipeServer, Encoding.UTF8);
						string message;
						while ((message = streamReader.ReadLine()) != null)
						{
							lock (_lockObject)
							{
								_mainThreadActions.Enqueue(delegate
								{
									ProcessMessage(message);
								});
							}
						}
					}
				}
				catch (Exception ex)
				{
					Debug.LogError((object)("命名管道错误: " + ex.Message));
				}
			}
		}

		private void ProcessMessage(string message)
		{
			try
			{
				string[] array = message.Split(new char[1] { '|' });
				if (array.Length >= 5 && array[0] == "TICKET_GIFT")
				{
					string text = array[1];
					int num = int.Parse(array[2]);
					string text2 = array[3];
					string text3 = array[4];
					Plugin.TicketManager?.ReceiveGiftAndUseTicket(text2, text3, text, num);
					Debug.Log((object)$"收到礼物: {text2} 送出 {text3} → {text} x{num}");
					_battleManager?.TriggerPunishment(text);
				}
				else if (array.Length >= 3 && array[0] == "TICKET_ADD")
				{
					string text4 = array[1];
					int num2 = int.Parse(array[2]);
					Plugin.TicketManager?.AddTicket(text4, num2);
					Debug.Log((object)$"收到票券: {text4} x{num2}");
					GiveGiftRewards(text4, num2);
					_battleManager?.TriggerPunishment(text4);
				}
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("处理消息错误: " + ex.Message));
			}
		}

		private void GiveGiftRewards(string ticketName, int ticketCount)
		{
			try
			{
				GiftReward reward = _giftConfig.GetReward(ticketName);
				if (reward == null || reward.rewards == null || reward.rewards.Length == 0 || GameMain.data == null)
				{
					return;
				}
				Player mainPlayer = GameMain.data.mainPlayer;
				if (mainPlayer == null)
				{
					return;
				}
				StorageComponent package = mainPlayer.package;
				if (package == null)
				{
					return;
				}
				string text = string.Empty;
				ItemReward[] rewards = reward.rewards;
				int num2 = default(int);
				foreach (ItemReward itemReward in rewards)
				{
					int num = itemReward.count * ticketCount;
					package.AddItem(itemReward.itemId, num, 0, ref num2, false);
					ItemProto val = ((ProtoSet<ItemProto>)(object)LDB.items).Select(itemReward.itemId);
					if (val != null)
					{
						text += $"{((Proto)val).name} x{num}, ";
					}
				}
				Debug.Log((object)("礼物回赠(" + ticketName + "): " + text.TrimEnd(',', ' ')));
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("礼物回赠失败: " + ex.Message));
			}
		}

		public void ProcessMessages()
		{
			lock (_lockObject)
			{
				while (_mainThreadActions.Count > 0)
				{
					_mainThreadActions.Dequeue()?.Invoke();
				}
			}
		}

		public void Stop()
		{
			_isRunning = false;
			_pipeServer?.Dispose();
			_listenThread?.Join();
		}
	}
	[BepInPlugin("com.dspzhibo.mod", "DspZhibo Mod", "1.1.0")]
	public class Plugin : BaseUnityPlugin
	{
		internal static Config Config;

		internal static WebSocketClient? WsClient;

		internal static TicketManager? TicketManager;

		private ConfigEntry<KeyboardShortcut> ToggleUIKey { get; set; }

		private ConfigEntry<string> WebSocketServerUrl { get; set; }

		private ConfigEntry<string> WebSocketToken { get; set; }

		private void Awake()
		{
			//IL_001c: Unknown result type (might be due to invalid IL or missing references)
			ToggleUIKey = ((BaseUnityPlugin)this).Config.Bind<KeyboardShortcut>("快捷键", "切换UI", new KeyboardShortcut((KeyCode)291, Array.Empty<KeyCode>()), "按此键切换奖券系统UI显示");
			WebSocketServerUrl = ((BaseUnityPlugin)this).Config.Bind<string>("WebSocket", "服务器地址", "ws://localhost:8080", "直播礼物客户端的WebSocket服务器地址");
			WebSocketToken = ((BaseUnityPlugin)this).Config.Bind<string>("WebSocket", "连接Token", "", "从客户端获取的连接Token，必须在启动游戏前配置");
			if (string.IsNullOrWhiteSpace(WebSocketToken.Value))
			{
				((BaseUnityPlugin)this).Logger.LogWarning((object)"========================================");
				((BaseUnityPlugin)this).Logger.LogWarning((object)"未配置WebSocket连接Token!");
				((BaseUnityPlugin)this).Logger.LogWarning((object)"请按以下步骤操作:");
				((BaseUnityPlugin)this).Logger.LogWarning((object)"1. 启动直播礼物客户端程序");
				((BaseUnityPlugin)this).Logger.LogWarning((object)"2. 访问 http://localhost:8080");
				((BaseUnityPlugin)this).Logger.LogWarning((object)"3. 在管理界面创建游戏客户端");
				((BaseUnityPlugin)this).Logger.LogWarning((object)"4. 复制生成的Token");
				((BaseUnityPlugin)this).Logger.LogWarning((object)"5. 编辑BepInEx/config/...com.dspzhibo.mod.cfg");
				((BaseUnityPlugin)this).Logger.LogWarning((object)"6. 在 WebSocket 连接Token 项中粘贴Token");
				((BaseUnityPlugin)this).Logger.LogWarning((object)"7. 保存文件后重新启动游戏");
				((BaseUnityPlugin)this).Logger.LogWarning((object)"========================================");
				UIRealtimeTip.Popup("未配置Token，无法连接到直播客户端！请查看日志", true, 0);
			}
			Config = new Config(((BaseUnityPlugin)this).Config);
			TicketManager = new TicketManager();
			if (!string.IsNullOrWhiteSpace(WebSocketToken.Value))
			{
				WsClient = new WebSocketClient(WebSocketServerUrl.Value, WebSocketToken.Value);
				WsClient.Start();
				((BaseUnityPlugin)this).Logger.LogInfo((object)("WebSocket客户端已启动，连接到: " + WebSocketServerUrl.Value));
				((BaseUnityPlugin)this).Logger.LogInfo((object)("使用Token: " + WebSocketToken.Value.Substring(0, Math.Min(8, WebSocketToken.Value.Length)) + "..."));
			}
			else
			{
				((BaseUnityPlugin)this).Logger.LogInfo((object)"由于未配置Token，WebSocket客户端未启动");
			}
			((BaseUnityPlugin)this).Logger.LogInfo((object)"插件 DspZhibo Mod 1.1.0 已加载!");
			((BaseUnityPlugin)this).Logger.LogInfo((object)"快捷键: F10 切换UI显示");
		}

		private void Update()
		{
			//IL_0018: Unknown result type (might be due to invalid IL or missing references)
			//IL_001d: Unknown result type (might be due to invalid IL or missing references)
			WsClient?.ProcessMessages();
			KeyboardShortcut value = ToggleUIKey.Value;
			if (((KeyboardShortcut)(ref value)).IsDown())
			{
				TicketManager?.ToggleUI();
			}
		}

		private void OnDestroy()
		{
			WsClient?.Stop();
			((BaseUnityPlugin)this).Logger.LogInfo((object)"插件已卸载");
		}

		private void OnGUI()
		{
			TicketManager?.OnGUI();
		}
	}
	[Serializable]
	public class PunishmentConfig
	{
		public bool enabled = true;

		public float spawnChance = 0.1f;

		public int minEnemyCount = 1;

		public int maxEnemyCount = 3;

		public string punishmentMessage = "小心！黑雾来袭！";

		public bool immediateSpawn = false;

		private static string _configPath => Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData), "DspZhibo", "PunishmentConfig.json");

		public static PunishmentConfig Load()
		{
			PunishmentConfig punishmentConfig = new PunishmentConfig();
			try
			{
				string directoryName = Path.GetDirectoryName(_configPath);
				if (!Directory.Exists(directoryName))
				{
					Directory.CreateDirectory(directoryName);
				}
				if (File.Exists(_configPath))
				{
					string text = File.ReadAllText(_configPath);
					punishmentConfig = JsonUtility.FromJson<PunishmentConfig>(text);
				}
				else
				{
					punishmentConfig = GetDefaultConfig();
					punishmentConfig.Save();
				}
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("加载惩罚配置失败: " + ex.Message));
				punishmentConfig = GetDefaultConfig();
			}
			return punishmentConfig;
		}

		public void Save()
		{
			try
			{
				string directoryName = Path.GetDirectoryName(_configPath);
				if (!Directory.Exists(directoryName))
				{
					Directory.CreateDirectory(directoryName);
				}
				string contents = JsonUtility.ToJson((object)this, true);
				File.WriteAllText(_configPath, contents);
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("保存惩罚配置失败: " + ex.Message));
			}
		}

		private static PunishmentConfig GetDefaultConfig()
		{
			return new PunishmentConfig
			{
				enabled = true,
				spawnChance = 0.1f,
				minEnemyCount = 1,
				maxEnemyCount = 3,
				punishmentMessage = "小心！黑雾来袭！",
				immediateSpawn = false
			};
		}

		public bool ShouldTriggerPunishment()
		{
			if (!enabled)
			{
				return false;
			}
			float value = Random.value;
			return value < spawnChance;
		}

		public int GetEnemyCount()
		{
			return Random.Range(minEnemyCount, maxEnemyCount + 1);
		}
	}
	public class TicketData
	{
		public int TicketId { get; set; }

		public string TicketName { get; set; } = string.Empty;


		public int Count { get; set; }

		public long Timestamp { get; set; }
	}
	public class TicketManager
	{
		[Serializable]
		private class TicketContainer
		{
			public List<TicketData> Tickets = new List<TicketData>();
		}

		[Serializable]
		private class GiftRecord
		{
			public string Time;

			public string Message;

			public string Reward;
		}

		private readonly List<TicketData> _tickets = new List<TicketData>();

		private readonly string _savePath;

		private bool _showUI = true;

		private Rect _windowRect = new Rect(20f, 20f, 450f, 400f);

		private Rect _configWindowRect = new Rect(500f, 20f, 400f, 500f);

		private Vector2 _scrollPosition;

		private string _resultMessage = string.Empty;

		private float _resultMessageTime;

		private List<ItemProto> _cachedItems;

		private GiftConfig _giftConfig;

		private Vector2 _configScrollPosition;

		private List<GiftRecord> _giftRecords = new List<GiftRecord>();

		private Vector2 _recordScrollPosition;

		public TicketManager()
		{
			//IL_0027: Unknown result type (might be due to invalid IL or missing references)
			//IL_002c: Unknown result type (might be due to invalid IL or missing references)
			//IL_0046: Unknown result type (might be due to invalid IL or missing references)
			//IL_004b: Unknown result type (might be due to invalid IL or missing references)
			_savePath = Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData), "DspZhibo", "tickets.json");
			LoadTickets();
			CacheItems();
			string text = Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData), "DspZhibo", "GiftConfig.json");
			Debug.Log((object)("[礼物配置] 配置文件路径: " + text));
			Debug.Log((object)$"[礼物配置] 文件存在: {File.Exists(text)}");
			_giftConfig = GiftConfig.Load();
			Debug.Log((object)$"[礼物配置] _giftConfig = {_giftConfig != null}");
			if (_giftConfig != null)
			{
				Debug.Log((object)$"[礼物配置] giftRewards = {_giftConfig.giftRewards}");
				Debug.Log((object)$"[礼物配置] giftRewards.Count = {_giftConfig.giftRewards?.Count ?? 0}");
			}
			if (_giftConfig != null && _giftConfig.giftRewards != null)
			{
				Debug.Log((object)$"[礼物配置] 已加载 {_giftConfig.giftRewards.Count} 种奖券配置:");
				{
					foreach (KeyValuePair<string, GiftReward> giftReward in _giftConfig.giftRewards)
					{
						Debug.Log((object)$"  - [{giftReward.Key}] -> {giftReward.Value?.ticketName} x{giftReward.Value?.ticketCount}");
					}
					return;
				}
			}
			Debug.LogWarning((object)"[礼物配置] 配置加载失败或为空");
		}

		private void CacheItems()
		{
			try
			{
				if ((Object)(object)LDB.items != (Object)null && ((ProtoSet<ItemProto>)(object)LDB.items).dataArray != null)
				{
					_cachedItems = ((ProtoSet<ItemProto>)(object)LDB.items).dataArray.Where((ItemProto item) => item != null && ((Proto)item).ID > 0 && item.GridIndex >= 0).ToList();
					Debug.Log((object)$"已缓存 {_cachedItems.Count} 个物品");
				}
				else
				{
					_cachedItems = new List<ItemProto>();
					Debug.LogWarning((object)"物品数据库未初始化");
				}
			}
			catch (Exception ex)
			{
				_cachedItems = new List<ItemProto>();
				Debug.LogError((object)("缓存物品失败: " + ex.Message));
			}
		}

		public void AddTicket(string ticketName, int count)
		{
			TicketData ticketData = _tickets.FirstOrDefault((TicketData t) => t.TicketName == ticketName);
			if (ticketData != null)
			{
				ticketData.Count += count;
			}
			else
			{
				_tickets.Add(new TicketData
				{
					TicketId = ((_tickets.Count <= 0) ? 1 : (_tickets.Max((TicketData t) => t.TicketId) + 1)),
					TicketName = ticketName,
					Count = count,
					Timestamp = DateTimeOffset.UtcNow.ToUnixTimeSeconds()
				});
			}
			SaveTickets();
		}

		public void ReceiveGiftAndUseTicket(string userName, string giftName, string ticketName, int ticketCount)
		{
			try
			{
				if (GameMain.data == null)
				{
					Debug.LogWarning((object)"GameMain.data 为空，无法使用奖券");
					return;
				}
				Player mainPlayer = GameMain.data.mainPlayer;
				if (mainPlayer == null)
				{
					Debug.LogWarning((object)"玩家为空，无法使用奖券");
					return;
				}
				StorageComponent package = mainPlayer.package;
				if (package == null)
				{
					Debug.LogWarning((object)"背包为空，无法使用奖券");
					return;
				}
				int rewardCount = GetRewardCount(ticketName);
				List<string> list = new List<string>();
				int num = default(int);
				for (int i = 0; i < ticketCount; i++)
				{
					Dictionary<int, int> randomItems = GetRandomItems(rewardCount);
					foreach (KeyValuePair<int, int> item2 in randomItems)
					{
						int key = item2.Key;
						int value = item2.Value;
						package.AddItem(key, value, 0, ref num, false);
						try
						{
							ItemProto val = ((ProtoSet<ItemProto>)(object)LDB.items).Select(key);
							if (val != null)
							{
								list.Add($"{((Proto)val).name} x{value}");
							}
						}
						catch
						{
							list.Add($"物品{key} x{value}");
						}
					}
				}
				string text = string.Join(", ", list);
				GiftRecord item = new GiftRecord
				{
					Message = "感谢 " + userName + " 送来的 " + giftName,
					Reward = "开出了: " + text,
					Time = DateTime.Now.ToString("HH:mm:ss")
				};
				_giftRecords.Add(item);
				if (_giftRecords.Count > 20)
				{
					_giftRecords.RemoveAt(0);
				}
				_showUI = true;
				Debug.Log((object)("[礼物] " + userName + " 送出 " + giftName + " → 开出了: " + text));
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("处理礼物失败: " + ex.Message));
			}
		}

		private Dictionary<string, int> UseTicketAndGetItems(string ticketName, int ticketCount)
		{
			Dictionary<string, int> dictionary = new Dictionary<string, int>();
			try
			{
				if (GameMain.data == null)
				{
					Debug.LogWarning((object)"GameMain.data 为空，无法发放奖励");
					return dictionary;
				}
				Player mainPlayer = GameMain.data.mainPlayer;
				if (mainPlayer == null)
				{
					Debug.LogWarning((object)"玩家为空，无法发放奖励");
					return dictionary;
				}
				StorageComponent package = mainPlayer.package;
				if (package == null)
				{
					Debug.LogWarning((object)"背包为空，无法发放奖励");
					return dictionary;
				}
				GiftReward giftReward = _giftConfig?.GetReward(ticketName);
				if (giftReward == null || giftReward.rewards == null || giftReward.rewards.Length == 0)
				{
					return dictionary;
				}
				ItemReward[] rewards = giftReward.rewards;
				int num2 = default(int);
				foreach (ItemReward itemReward in rewards)
				{
					int num = itemReward.count * ticketCount;
					package.AddItem(itemReward.itemId, num, 0, ref num2, false);
					try
					{
						ItemProto val = ((ProtoSet<ItemProto>)(object)LDB.items).Select(itemReward.itemId);
						if (val != null)
						{
							string name = ((Proto)val).name;
							if (dictionary.ContainsKey(name))
							{
								dictionary[name] += num;
							}
							else
							{
								dictionary[name] = num;
							}
						}
					}
					catch
					{
						if (dictionary.ContainsKey($"物品{itemReward.itemId}"))
						{
							dictionary[$"物品{itemReward.itemId}"] += num;
						}
						else
						{
							dictionary[$"物品{itemReward.itemId}"] = num;
						}
					}
				}
				TicketData ticketData = _tickets.FirstOrDefault((TicketData t) => t.TicketName == ticketName);
				if (ticketData != null)
				{
					ticketData.Count -= ticketCount;
					if (ticketData.Count <= 0)
					{
						_tickets.Remove(ticketData);
					}
					SaveTickets();
				}
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("使用奖券失败: " + ex.Message));
			}
			return dictionary;
		}

		public void UseTicket(int ticketId)
		{
			try
			{
				TicketData ticketData = _tickets.FirstOrDefault((TicketData t) => t.TicketId == ticketId);
				if (ticketData != null)
				{
					GiveRandomItems(ticketData.TicketName);
					ticketData.Count--;
					if (ticketData.Count <= 0)
					{
						_tickets.Remove(ticketData);
					}
					SaveTickets();
				}
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("使用奖券失败: " + ex.Message + "\n" + ex.StackTrace));
			}
		}

		public void UseAllTickets()
		{
			try
			{
				if (GameMain.data == null)
				{
					Debug.LogWarning((object)"GameMain.data 为空，无法使用奖券");
					return;
				}
				Player mainPlayer = GameMain.data.mainPlayer;
				if (mainPlayer == null)
				{
					Debug.LogWarning((object)"玩家为空，无法使用奖券");
					return;
				}
				StorageComponent package = mainPlayer.package;
				if (package == null)
				{
					Debug.LogWarning((object)"背包为空，无法使用奖券");
					return;
				}
				if (_tickets.Count == 0)
				{
					_resultMessage = "暂无奖券可使用";
					_resultMessageTime = Time.realtimeSinceStartup;
					return;
				}
				Dictionary<string, int> dictionary = new Dictionary<string, int>();
				List<string> list = new List<string>();
				List<TicketData> list2 = _tickets.ToList();
				int num = default(int);
				foreach (TicketData item in list2)
				{
					int rewardCount = GetRewardCount(item.TicketName);
					for (int i = 0; i < item.Count; i++)
					{
						Dictionary<int, int> randomItems = GetRandomItems(rewardCount);
						foreach (KeyValuePair<int, int> item2 in randomItems)
						{
							int key = item2.Key;
							int value = item2.Value;
							package.AddItem(key, value, 0, ref num, false);
							try
							{
								ItemProto val = ((ProtoSet<ItemProto>)(object)LDB.items).Select(key);
								if (val != null)
								{
									string name = ((Proto)val).name;
									if (dictionary.ContainsKey(name))
									{
										dictionary[name] += value;
									}
									else
									{
										dictionary[name] = value;
									}
								}
							}
							catch
							{
								string key2 = $"物品{key}";
								if (dictionary.ContainsKey(key2))
								{
									dictionary[key2] += value;
								}
								else
								{
									dictionary[key2] = value;
								}
							}
						}
					}
					list.Add($"{item.TicketName} x{item.Count}");
				}
				_tickets.Clear();
				SaveTickets();
				string text = string.Join(", ", dictionary.Select((KeyValuePair<string, int> kv) => $"{kv.Value}x{kv.Key}"));
				_resultMessage = "已使用所有奖券:\n" + string.Join(", ", list) + "\n\n开出物品:\n" + text;
				_resultMessageTime = Time.realtimeSinceStartup;
				Debug.Log((object)("[使用所有奖券] " + string.Join(", ", list) + " → " + text));
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("使用所有奖券失败: " + ex.Message + "\n" + ex.StackTrace));
			}
		}

		private void GiveItemsFromTicket(string ticketName, int ticketCount)
		{
			try
			{
				if (GameMain.data == null)
				{
					return;
				}
				Player mainPlayer = GameMain.data.mainPlayer;
				if (mainPlayer == null)
				{
					return;
				}
				StorageComponent package = mainPlayer.package;
				if (package == null)
				{
					return;
				}
				GiftReward giftReward = _giftConfig?.GetReward(ticketName);
				if (giftReward != null && giftReward.rewards != null && giftReward.rewards.Length != 0)
				{
					ItemReward[] rewards = giftReward.rewards;
					int num2 = default(int);
					foreach (ItemReward itemReward in rewards)
					{
						int num = itemReward.count * ticketCount;
						package.AddItem(itemReward.itemId, num, 0, ref num2, false);
					}
				}
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("发放物品失败: " + ex.Message));
			}
		}

		private void GiveRandomItems(string ticketName)
		{
			try
			{
				if (GameMain.data == null)
				{
					Debug.LogWarning((object)"GameMain.data 为空，无法发放奖励");
					return;
				}
				Player mainPlayer = GameMain.data.mainPlayer;
				if (mainPlayer == null)
				{
					Debug.LogWarning((object)"玩家为空，无法发放奖励");
					return;
				}
				StorageComponent package = mainPlayer.package;
				if (package == null)
				{
					Debug.LogWarning((object)"背包为空，无法发放奖励");
					return;
				}
				int rewardCount = GetRewardCount(ticketName);
				Dictionary<int, int> randomItems = GetRandomItems(rewardCount);
				string text = string.Empty;
				int num = default(int);
				foreach (KeyValuePair<int, int> item in randomItems)
				{
					int key = item.Key;
					int value = item.Value;
					package.AddItem(key, value, 0, ref num, false);
					try
					{
						ItemProto val = ((ProtoSet<ItemProto>)(object)LDB.items).Select(key);
						if (val != null)
						{
							text += $"{((Proto)val).name} x{value}, ";
						}
					}
					catch
					{
						text += $"物品{key} x{value}, ";
					}
				}
				_resultMessage = "使用 " + ticketName + " 获得:\n" + text.TrimEnd(',', ' ');
				_resultMessageTime = Time.realtimeSinceStartup;
				Debug.Log((object)("奖券使用: " + ticketName + " - " + text));
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("发放奖励失败: " + ex.Message + "\n" + ex.StackTrace));
			}
		}

		private int GetRewardCount(string ticketName)
		{
			if (ticketName.Contains("VIP"))
			{
				return 5;
			}
			if (ticketName.Contains("稀有"))
			{
				return 2;
			}
			return 1;
		}

		private Dictionary<int, int> GetRandomItems(int count)
		{
			Dictionary<int, int> dictionary = new Dictionary<int, int>();
			Random random = new Random();
			if (_cachedItems == null || _cachedItems.Count == 0)
			{
				Debug.LogWarning((object)"物品缓存为空，尝试重新加载");
				CacheItems();
			}
			if (_cachedItems == null || _cachedItems.Count == 0)
			{
				Debug.LogWarning((object)"没有可用的物品");
				return dictionary;
			}
			for (int i = 0; i < count; i++)
			{
				int index = random.Next(_cachedItems.Count);
				ItemProto val = _cachedItems[index];
				if (dictionary.ContainsKey(((Proto)val).ID))
				{
					dictionary[((Proto)val).ID]++;
				}
				else
				{
					dictionary[((Proto)val).ID] = 1;
				}
			}
			return dictionary;
		}

		private void SaveTickets()
		{
			try
			{
				string directoryName = Path.GetDirectoryName(_savePath);
				if (!Directory.Exists(directoryName))
				{
					Directory.CreateDirectory(directoryName);
				}
				string contents = JsonUtility.ToJson((object)new TicketContainer
				{
					Tickets = _tickets
				}, true);
				File.WriteAllText(_savePath, contents);
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("保存票券失败: " + ex.Message));
			}
		}

		private void LoadTickets()
		{
			try
			{
				if (File.Exists(_savePath))
				{
					string text = File.ReadAllText(_savePath);
					TicketContainer ticketContainer = JsonUtility.FromJson<TicketContainer>(text);
					_tickets.Clear();
					_tickets.AddRange(ticketContainer.Tickets);
					Debug.Log((object)$"已加载 {_tickets.Count} 种票券");
				}
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("加载票券失败: " + ex.Message));
			}
		}

		public void ToggleUI()
		{
			_showUI = !_showUI;
			Debug.Log((object)$"UI显示: {_showUI}");
		}

		public void OnGUI()
		{
			//IL_0008: Unknown result type (might be due to invalid IL or missing references)
			//IL_0014: Unknown result type (might be due to invalid IL or missing references)
			//IL_0023: Expected O, but got Unknown
			//IL_001e: Unknown result type (might be due to invalid IL or missing references)
			//IL_0023: Unknown result type (might be due to invalid IL or missing references)
			//IL_003a: Unknown result type (might be due to invalid IL or missing references)
			//IL_0046: Unknown result type (might be due to invalid IL or missing references)
			//IL_0055: Expected O, but got Unknown
			//IL_0050: Unknown result type (might be due to invalid IL or missing references)
			//IL_0055: Unknown result type (might be due to invalid IL or missing references)
			_configWindowRect = GUI.Window(12346, _configWindowRect, new WindowFunction(DrawConfigWindow), "礼物配置");
			if (_showUI)
			{
				_windowRect = GUI.Window(12345, _windowRect, new WindowFunction(DrawWindow), "奖券系统");
			}
		}

		private void DrawWindow(int windowId)
		{
			//IL_0028: Unknown result type (might be due to invalid IL or missing references)
			//IL_0040: Unknown result type (might be due to invalid IL or missing references)
			//IL_0045: Unknown result type (might be due to invalid IL or missing references)
			GUILayout.BeginVertical(Array.Empty<GUILayoutOption>());
			GUILayout.Label("奖券系统 (按 F10 切换显示)", GUI.skin.box, Array.Empty<GUILayoutOption>());
			_recordScrollPosition = GUILayout.BeginScrollView(_recordScrollPosition, (GUILayoutOption[])(object)new GUILayoutOption[1] { GUILayout.Height(320f) });
			if (_giftRecords.Count == 0)
			{
				GUILayout.Label("暂无礼物记录", (GUILayoutOption[])(object)new GUILayoutOption[1] { GUILayout.Height(40f) });
			}
			else
			{
				for (int num = _giftRecords.Count - 1; num >= 0; num--)
				{
					GiftRecord giftRecord = _giftRecords[num];
					GUILayout.BeginVertical(GUI.skin.box, Array.Empty<GUILayoutOption>());
					GUILayout.BeginHorizontal(Array.Empty<GUILayoutOption>());
					GUILayout.Label("[" + giftRecord.Time + "]", (GUILayoutOption[])(object)new GUILayoutOption[1] { GUILayout.Width(60f) });
					GUILayout.Label(giftRecord.Message, Array.Empty<GUILayoutOption>());
					GUILayout.EndHorizontal();
					GUILayout.Label(giftRecord.Reward, Array.Empty<GUILayoutOption>());
					GUILayout.EndVertical();
					GUILayout.Space(2f);
				}
			}
			GUILayout.EndScrollView();
			if (GUILayout.Button("关闭", (GUILayoutOption[])(object)new GUILayoutOption[1] { GUILayout.Height(30f) }))
			{
				_showUI = false;
			}
			GUILayout.EndVertical();
			GUI.DragWindow();
		}

		private void DrawConfigWindow(int windowId)
		{
			//IL_0180: Unknown result type (might be due to invalid IL or missing references)
			//IL_018a: Unknown result type (might be due to invalid IL or missing references)
			//IL_018f: Unknown result type (might be due to invalid IL or missing references)
			GUILayout.BeginVertical(Array.Empty<GUILayoutOption>());
			GUILayout.Label("礼物 → 奖券 → 物品 配置", GUI.skin.box, Array.Empty<GUILayoutOption>());
			GUILayout.Label("此窗口可调整大小，无法关闭", (GUILayoutOption[])(object)new GUILayoutOption[1] { GUILayout.Height(20f) });
			GUILayout.Label("━━━━━━━━━━━━━━━━━━━━━━━━━━━━", (GUILayoutOption[])(object)new GUILayoutOption[1] { GUILayout.Height(15f) });
			try
			{
				if (GameMain.data != null && GameMain.data.localStar != null)
				{
					StarData localStar = GameMain.data.localStar;
					int threatValue = DFSystemManager.GetThreatValue();
					GUILayout.BeginHorizontal(GUI.skin.box, Array.Empty<GUILayoutOption>());
					GUILayout.Label("⚠\ufe0f 当前星区: " + localStar.displayName, Array.Empty<GUILayoutOption>());
					GUILayout.FlexibleSpace();
					GUILayout.Label($"威胁度: {threatValue}", (GUILayoutOption[])(object)new GUILayoutOption[1] { GUILayout.Width(80f) });
					GUILayout.EndHorizontal();
					int num = (int)Math.Ceiling((double)threatValue / 10.0);
					GUILayout.Label($"预计敌人波数: {num} 波 (每波约3个敌人)", Array.Empty<GUILayoutOption>());
				}
				else
				{
					GUILayout.Label("⚠\ufe0f 未进入游戏或未在星区中", Array.Empty<GUILayoutOption>());
				}
			}
			catch (Exception ex)
			{
				GUILayout.Label("⚠\ufe0f 无法获取威胁度: " + ex.Message, Array.Empty<GUILayoutOption>());
			}
			GUILayout.Label("━━━━━━━━━━━━━━━━━━━━━━━━━━━━", (GUILayoutOption[])(object)new GUILayoutOption[1] { GUILayout.Height(15f) });
			_configScrollPosition = GUILayout.BeginScrollView(_configScrollPosition, Array.Empty<GUILayoutOption>());
			if (_giftConfig != null && _giftConfig.giftRewards != null)
			{
				foreach (KeyValuePair<string, GiftReward> giftReward in _giftConfig.giftRewards)
				{
					string key = giftReward.Key;
					GiftReward value = giftReward.Value;
					if (value == null)
					{
						continue;
					}
					GUILayout.BeginVertical(GUI.skin.box, Array.Empty<GUILayoutOption>());
					GUILayout.BeginHorizontal(Array.Empty<GUILayoutOption>());
					GUILayout.Label("\ud83c\udf81 礼物:", (GUILayoutOption[])(object)new GUILayoutOption[1] { GUILayout.Width(60f) });
					GUILayout.Label(key, (GUILayoutOption[])(object)new GUILayoutOption[1] { GUILayout.Width(150f) });
					GUILayout.FlexibleSpace();
					GUILayout.Label("→", (GUILayoutOption[])(object)new GUILayoutOption[1] { GUILayout.Width(20f) });
					GUILayout.Label(value.ticketName, (GUILayoutOption[])(object)new GUILayoutOption[1] { GUILayout.Width(100f) });
					GUILayout.Label($"x{value.ticketCount}", (GUILayoutOption[])(object)new GUILayoutOption[1] { GUILayout.Width(40f) });
					GUILayout.EndHorizontal();
					string dangerInfo = GetDangerInfo(value.ticketName);
					if (!string.IsNullOrEmpty(dangerInfo))
					{
						GUILayout.Label("   ⚠\ufe0f " + dangerInfo, Array.Empty<GUILayoutOption>());
					}
					if (value.rewards != null && value.rewards.Length != 0)
					{
						GUILayout.Label("   奖励物品:", Array.Empty<GUILayoutOption>());
						ItemReward[] rewards = value.rewards;
						foreach (ItemReward itemReward in rewards)
						{
							try
							{
								ItemProto val = ((ProtoSet<ItemProto>)(object)LDB.items).Select(itemReward.itemId);
								string arg = ((val != null) ? ((Proto)val).name : $"物品{itemReward.itemId}");
								GUILayout.Label($"   • {arg} x{itemReward.count}", Array.Empty<GUILayoutOption>());
							}
							catch
							{
								GUILayout.Label($"   • 物品{itemReward.itemId} x{itemReward.count}", Array.Empty<GUILayoutOption>());
							}
						}
					}
					GUILayout.EndVertical();
					GUILayout.Space(5f);
				}
			}
			else
			{
				GUILayout.Label("未找到礼物配置", GUI.skin.box, Array.Empty<GUILayoutOption>());
			}
			GUILayout.EndScrollView();
			if (GUILayout.Button("刷新配置", Array.Empty<GUILayoutOption>()))
			{
				_giftConfig = GiftConfig.Load();
				Debug.Log((object)"配置已刷新");
			}
			GUILayout.EndVertical();
			GUI.DragWindow();
		}

		private string GetDangerInfo(string ticketName)
		{
			if (ticketName.Contains("普通"))
			{
				return "50%概率触发黑雾 (威胁度+20)";
			}
			if (ticketName.Contains("稀有"))
			{
				return "10%概率触发黑雾 (威胁度+10)";
			}
			if (ticketName.Contains("VIP"))
			{
				return "不触发黑雾";
			}
			return "";
		}
	}
	public class WebSocketClient
	{
		private readonly string _serverUrl;

		private readonly string _token;

		private ClientWebSocket? _webSocket;

		private Thread? _receiveThread;

		private bool _isRunning;

		private readonly ConcurrentQueue<Action> _mainThreadActions = new ConcurrentQueue<Action>();

		private DateTime _lastReconnectAttempt = DateTime.MinValue;

		private readonly TimeSpan _reconnectInterval = TimeSpan.FromSeconds(30.0);

		private GiftConfig _giftConfig;

		private BattleManager _battleManager;

		public bool IsConnected { get; private set; }

		public WebSocketClient(string serverUrl = "ws://localhost:8080", string token = "")
		{
			_serverUrl = serverUrl;
			_token = token;
			_giftConfig = GiftConfig.Load();
			_battleManager = new BattleManager();
		}

		public void Start()
		{
			_isRunning = true;
			_receiveThread = new Thread(ReceiveLoop)
			{
				IsBackground = true
			};
			_receiveThread.Start();
			Debug.Log((object)("[WebSocket] 客户端已启动，连接到: " + _serverUrl));
		}

		private async void ReceiveLoop()
		{
			while (_isRunning)
			{
				if (!IsConnected)
				{
					TimeSpan timeSinceLastAttempt = DateTime.Now - _lastReconnectAttempt;
					if (timeSinceLastAttempt >= _reconnectInterval)
					{
						_lastReconnectAttempt = DateTime.Now;
						await ConnectAsync();
						continue;
					}
					double waitTime = (_reconnectInterval - timeSinceLastAttempt).TotalSeconds;
					Debug.Log((object)$"[WebSocket] 等待 {waitTime:F0} 秒后重连...");
					TimeSpan reconnectInterval = _reconnectInterval;
					await Task.Delay((int)reconnectInterval.TotalMilliseconds / 10);
					continue;
				}
				try
				{
					byte[] buffer = new byte[4096];
					WebSocketReceiveResult result = await _webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
					if (result.MessageType == WebSocketMessageType.Close)
					{
						Debug.Log((object)"[WebSocket] 服务器关闭连接");
						await CloseAsync();
					}
					else if (result.MessageType == WebSocketMessageType.Text)
					{
						string message = Encoding.UTF8.GetString(buffer, 0, result.Count);
						_mainThreadActions.Enqueue(delegate
						{
							ProcessMessage(message);
						});
					}
				}
				catch (Exception ex)
				{
					Debug.LogError((object)("[WebSocket] 接收消息错误: " + ex.Message));
					await CloseAsync();
				}
			}
		}

		private async Task ConnectAsync()
		{
			try
			{
				UriBuilder uriBuilder = new UriBuilder(_serverUrl);
				if (string.IsNullOrEmpty(uriBuilder.Query))
				{
					uriBuilder.Query = "token=" + Uri.EscapeDataString(_token);
				}
				else
				{
					uriBuilder.Query = uriBuilder.Query + "&token=" + Uri.EscapeDataString(_token);
				}
				Debug.Log((object)("[WebSocket] 正在连接到 " + _serverUrl + "..."));
				_webSocket = new ClientWebSocket();
				await _webSocket.ConnectAsync(uriBuilder.Uri, CancellationToken.None);
				if (_webSocket.State == WebSocketState.Open)
				{
					IsConnected = true;
					Debug.Log((object)"[WebSocket] ✓ 成功连接到客户端");
					UIRealtimeTip.Popup("已连接到直播礼物客户端", false, 0);
					string authMsg = "AUTH|" + _token;
					byte[] buffer = Encoding.UTF8.GetBytes(authMsg);
					await _webSocket.SendAsync(new ArraySegment<byte>(buffer), WebSocketMessageType.Text, endOfMessage: true, CancellationToken.None);
					SendConfigToClient();
				}
			}
			catch (Exception ex2)
			{
				Exception ex = ex2;
				Debug.LogError((object)("[WebSocket] 连接失败: " + ex.Message));
				IsConnected = false;
				_webSocket?.Dispose();
				_webSocket = null;
			}
		}

		private async void SendConfigToClient()
		{
			try
			{
				ClientWebSocket? webSocket = _webSocket;
				if (webSocket == null || webSocket.State != WebSocketState.Open)
				{
					Debug.LogWarning((object)"[WebSocket] 无法发送配置：连接未建立");
					return;
				}
				string configPath = Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData), "DspZhibo", "GiftConfig.json");
				if (!File.Exists(configPath))
				{
					Debug.LogWarning((object)("[WebSocket] 配置文件不存在: " + configPath));
					return;
				}
				string configJson = File.ReadAllText(configPath);
				string configMsg = "CONFIG_SYNC|" + configJson;
				byte[] buffer = Encoding.UTF8.GetBytes(configMsg);
				await _webSocket.SendAsync(new ArraySegment<byte>(buffer), WebSocketMessageType.Text, endOfMessage: true, CancellationToken.None);
				Debug.Log((object)"[WebSocket] ✓ 已发送配置给客户端");
			}
			catch (Exception ex2)
			{
				Exception ex = ex2;
				Debug.LogError((object)("[WebSocket] 发送配置失败: " + ex.Message));
			}
		}

		private async Task CloseAsync()
		{
			IsConnected = false;
			if (_webSocket != null)
			{
				try
				{
					await _webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, "Closing", CancellationToken.None);
				}
				catch
				{
				}
				_webSocket.Dispose();
				_webSocket = null;
			}
			Debug.Log((object)"[WebSocket] 连接已关闭");
		}

		private void ProcessMessage(string message)
		{
			try
			{
				string[] array = message.Split(new char[1] { '|' });
				if (array.Length >= 5 && array[0] == "TICKET_GIFT")
				{
					string text = array[1];
					int num = int.Parse(array[2]);
					string text2 = array[3];
					string text3 = array[4];
					Plugin.TicketManager?.ReceiveGiftAndUseTicket(text2, text3, text, num);
					Debug.Log((object)$"[礼物] {text2} 送出 {text3} → {text} x{num}");
					_battleManager?.TriggerPunishment(text);
				}
				else if (array.Length >= 3 && array[0] == "TICKET_ADD")
				{
					string text4 = array[1];
					int num2 = int.Parse(array[2]);
					Plugin.TicketManager?.AddTicket(text4, num2);
					Debug.Log((object)$"[票券] 收到票券: {text4} x{num2}");
					GiveGiftRewards(text4, num2);
					_battleManager?.TriggerPunishment(text4);
				}
				else if (array.Length >= 2 && array[0] == "CONFIG_UPDATE")
				{
					string text5 = message.Substring("CONFIG_UPDATE|".Length);
					Debug.Log((object)$"[配置] 收到新配置，长度: {text5.Length}");
				}
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("[WebSocket] 处理消息错误: " + ex.Message));
			}
		}

		private void GiveGiftRewards(string ticketName, int ticketCount)
		{
			try
			{
				GiftReward reward = _giftConfig.GetReward(ticketName);
				if (reward == null || reward.rewards == null || reward.rewards.Length == 0 || GameMain.data == null)
				{
					return;
				}
				Player mainPlayer = GameMain.data.mainPlayer;
				if (mainPlayer == null)
				{
					return;
				}
				StorageComponent package = mainPlayer.package;
				if (package == null)
				{
					return;
				}
				string text = string.Empty;
				ItemReward[] rewards = reward.rewards;
				int num2 = default(int);
				foreach (ItemReward itemReward in rewards)
				{
					int num = itemReward.count * ticketCount;
					package.AddItem(itemReward.itemId, num, 0, ref num2, false);
					ItemProto val = ((ProtoSet<ItemProto>)(object)LDB.items).Select(itemReward.itemId);
					if (val != null)
					{
						text += $"{((Proto)val).name} x{num}, ";
					}
				}
				Debug.Log((object)("[回赠] " + ticketName + ": " + text.TrimEnd(',', ' ')));
			}
			catch (Exception ex)
			{
				Debug.LogError((object)("[回赠] 失败: " + ex.Message));
			}
		}

		public void ProcessMessages()
		{
			Action result;
			while (_mainThreadActions.TryDequeue(out result))
			{
				result?.Invoke();
			}
		}

		public void Stop()
		{
			_isRunning = false;
			CloseAsync().GetAwaiter().GetResult();
			_receiveThread?.Join();
		}
	}
}