add new facture gw

Author: Dark25

Core/LowPriorityWorker.cs

@@ -1,4 +1,5 @@
 using Akiled.Database.Interfaces;
+using AkiledEmulator.HabboHotel.Hotel.Giveaway;
 using System;
 using System.Diagnostics;
 
@@ -28,6 +29,32 @@ public static void Init()
         private static Stopwatch lowPriorityProcessWatch;
         public static void Process()
         {
+            if (lowPriorityProcessWatch.ElapsedMilliseconds >= 60000 && isExecuted)
+            {
+                try
+                {
+                    if (GiveAwayConfigs.enabled)
+                    {
+                        if (GiveAwayConfigs.timestamp < AkiledEnvironment.GetUnixTimestamp())
+                        {
+                            try
+                            {
+                                GiveAwayConfigs.Stop();
+                                
+                            }
+                            catch (Exception ex)
+                            {
+                                Logging.LogException(ex.ToString());
+                            }
+                        }
+                    }
+                }
+                catch
+                {
+
+                }
+            }
+
             if (lowPriorityProcessWatch.ElapsedMilliseconds >= 60000 || !isExecuted)
             {
                 isExecuted = true;

HabboHotel/Game.cs

@@ -23,9 +23,11 @@
 using Akiled.HabboHotel.Support;
 using Akiled.HabboHotel.Users.Messenger;
 using Akiled.HabboHotel.WebClients;
+using AkiledEmulator.HabboHotel.Hotel.Giveaway;
 using System;
 using System.Diagnostics;
 using System.Threading;
+using static Akiled.HabboHotel.Rooms.Chat.Commands.Cmd.UserInfo;
 
 namespace Akiled.HabboHotel
 {
@@ -55,6 +57,8 @@ public class Game
         private readonly CacheManager _cacheManager;
         private readonly CrackableManager _crackableManager;
         private readonly CraftingManager _craftingManager;
+        private readonly GiveAwayBlocksManager _giveAwayBlocksM;
+
         private Thread gameLoop; //Task
         public static bool gameLoopEnabled = true;
         public bool gameLoopActive;
@@ -115,6 +119,7 @@ public Game()
             this._craftingManager.Init();
             this._notiftopManager = new NotificationTopManager();
             this._notiftopManager.Init();
+
             using (IQueryAdapter dbClient = AkiledEnvironment.GetDatabaseManager().GetQueryReactor())
             {
                 StaffChat.Initialize(dbClient);
@@ -125,6 +130,8 @@ public Game()
             LowPriorityWorker.Init();
 
             this.moduleWatch = new Stopwatch();
+
+            this._giveAwayBlocksM = new GiveAwayBlocksManager();
         }
 
         #region Return values
@@ -225,6 +232,8 @@ public QuestManager GetQuestManager()
 
         public HotelViewManager GetHotelView() => this._hotelViewManager;
 
+        public GiveAwayBlocksManager GetGiveAwayBlocks() => _giveAwayBlocksM;
+
         #endregion
 
         public void StartGameLoop()
@@ -264,12 +273,8 @@ private void MainGameLoop()
                     if (gameLoopEnabled)
                     {
                         moduleWatch.Restart();
-
-
                         LowPriorityWorker.Process();
-
-
-
+                        
                         if (moduleWatch.ElapsedMilliseconds > 500)
                             Console.WriteLine("High latency in LowPriorityWorker.Process ({0} ms)", moduleWatch.ElapsedMilliseconds);
                         moduleWatch.Restart();

HabboHotel/GameClients/GameClientManager.cs

@@ -492,6 +492,25 @@ public Task BanUserAsync(GameClient Client, string Moderator, double LengthSecon
 
         public void SendSuperNotif(string Title, string Notice, string Picture, string Link, string LinkTitle, bool Broadcast, bool Event) => this.SendMessage(new RoomNotificationComposer(Title, Notice, Picture, LinkTitle, Link));
 
+        public void SendWhisper(string Message, int Colour = 0)
+        {
+            try
+            {
+                foreach (GameClient Client in this._clients.Values.ToList())
+                {
+                    RoomUser User = Client.GetHabbo().CurrentRoom.GetRoomUserManager().GetRoomUserByHabbo(Client.GetHabbo().Username);
+                    if (User == null || User.IsBot || User.IsPet)
+                        continue;
+
+                    SendMessage(new WhisperMessageComposer(User.VirtualId, Message, 0, Colour == 0 ? User.LastBubble : Colour));
+                }
+            }
+            catch (Exception e)
+            {
+                Logging.HandleException(e, "GameClientManager.SendWhisper");
+            }
+        }
+
         private void GiveDiamonds()
         {
             if (diamondsQueuee.Count > 0)

HabboHotel/Hotel/Extras/RewardsOffline.cs

@@ -0,0 +1,24 @@
+using Akiled;
+using Akiled.Database.Interfaces;
+
+namespace AkiledEmulator.HabboHotel.Hotel.Extras
+{
+    public class RewardsOffline
+    {
+        public static void Rewards(int userId, int credits, int duckets, int diamonds, string badge, int item)
+        {
+            if (userId <= 0)
+                return;
+
+            using (IQueryAdapter dbClient = AkiledEnvironment.GetDatabaseManager().GetQueryReactor())
+            {
+                dbClient.RunQuery("UPDATE `users` SET `credits`=credits + " + credits + ", `activity_points`=activity_points + " + duckets + ", `vip_points`=vip_points + " + diamonds + " WHERE `id`=" + userId + " LIMIT 1");
+
+                if (!string.IsNullOrEmpty(badge))
+                    dbClient.RunQuery("INSERT INTO `user_badges` (user_id, badge_id, badge_slot) VALUES (" + userId + ", '" + badge + "', 0)");
+                if (item > 0)
+                    dbClient.RunQuery("INSERT INTO `items` (user_id, room_id, base_item) VALUES (" + userId + ", 0, " + item + ")");
+            }
+        }
+    }
+}

HabboHotel/Hotel/Giveaway/GiveAwayBlocksManager.cs

@@ -0,0 +1,83 @@
+using Akiled;
+using Akiled.Database.Interfaces;
+using System;
+using System.Collections.Generic;
+using System.Data;
+
+namespace AkiledEmulator.HabboHotel.Hotel.Giveaway
+{
+    public class GiveAwayBlocksManager
+    {
+        private Dictionary<int, GiveAwayBlocks> giveAwayBlock;
+
+        public GiveAwayBlocksManager()
+        {
+            giveAwayBlock = new Dictionary<int, GiveAwayBlocks>();
+            Init(AkiledEnvironment.GetDatabaseManager().GetQueryReactor());
+        }
+
+        public void Init(IQueryAdapter dbClient)
+        {
+            if (giveAwayBlock.Count > 0)
+                giveAwayBlock.Clear();
+
+            dbClient.SetQuery("SELECT user_id, added FROM give_away_blocks");
+            DataTable dataTable = dbClient.GetTable();
+
+            if (dataTable != null)
+                foreach (DataRow row in dataTable.Rows)
+                    giveAwayBlock.Add(Convert.ToInt32(row["user_id"]), new GiveAwayBlocks(Convert.ToInt32(row["user_id"]), Convert.ToDouble(row["added"])));
+        }
+
+        public void InsertBlock(int userId)
+        {
+            if (!giveAwayBlock.ContainsKey(userId))
+            {
+                double time = AkiledEnvironment.GetUnixTimestamp() + (GiveAwayConfigs.durationOfBlock * 60);
+                using (IQueryAdapter dbClient = AkiledEnvironment.GetDatabaseManager().GetQueryReactor())
+                    dbClient.RunQuery("INSERT INTO give_away_blocks (user_id,added) VALUES (" + userId + ", " + time + ")");
+
+                giveAwayBlock.Add(userId, new GiveAwayBlocks(userId, time));
+            }
+        }
+
+        private void RemoveBlock(int userId)
+        {
+            if (giveAwayBlock.ContainsKey(userId))
+            {
+                using (IQueryAdapter dbClient = AkiledEnvironment.GetDatabaseManager().GetQueryReactor())
+                    dbClient.RunQuery("DELETE FROM give_away_blocks WHERE user_id = " + userId);
+
+                giveAwayBlock.Remove(userId);
+            }
+        }
+
+        public bool CheckTimeExpire(int userId, GiveAwayBlocks giveAwayBlocks)
+        {
+            if (giveAwayBlocks.timestamp > AkiledEnvironment.GetUnixTimestamp())
+                return true;
+
+            RemoveBlock(userId);
+            return false;
+        }
+
+        public bool TryGet(int userId, out GiveAwayBlocks giveAwayBlocks)
+        {
+            if (giveAwayBlock.TryGetValue(userId, out giveAwayBlocks))
+                return true;
+            return false;
+        }
+    }
+
+    public class GiveAwayBlocks
+    {
+        public int userId { get; set; }
+        public double timestamp { get; set; }
+
+        public GiveAwayBlocks(int userId, double added)
+        {
+            this.userId = userId;
+            this.timestamp = added;
+        }
+    }
+}