namespace Holo.Managers
{
    using Holo;
    using Ion.Storage;
    using System;
    using System.Collections;
    using System.Data;
    using System.Threading;

    public static class recyclerManager
    {
        private static int itemMinOwnershipLength;
        private static int sessionExpireLength;
        private static int sessionLength;
        private static Hashtable sessionRewards;
        public static string setupString;

        public static void createSession(int userID, int itemCount)
        {
            int val = (int) sessionRewards[itemCount];
            using (DatabaseClient client = Eucalypt.dbManager.GetClient())
            {
                client.AddParamWithValue("userID", userID);
                client.AddParamWithValue("dateTime", DateTime.Now.ToString());
                client.AddParamWithValue("rewardTemplateID", val);
                client.runQuery("INSERT INTO users_recycler(userid,session_started,session_reward) VALUES (@userID, @dateTime, @rewardTemplateID)");
            }
        }

        public static void dropSession(int userID, bool dropItems)
        {
            using (DatabaseClient client = Eucalypt.dbManager.GetClient())
            {
                client.runQuery("DELETE FROM users_recycler WHERE userid = '" + userID + "' LIMIT 1");
                if (dropItems)
                {
                    client.runQuery("DELETE FROM furniture WHERE ownerid = '" + userID + "' AND roomid = '-2'");
                }
                else
                {
                    client.runQuery("UPDATE furniture SET roomid = '0' WHERE ownerid = '" + userID + "' AND roomid = '-2'");
                }
            }
        }

        public static void Init(bool Update)
        {
            if (Config.getTableEntry("recycler_enable") == "1")
            {
                DataTable table;
                Config.enableRecycler = true;
                Out.WriteLine("Initializing recycler...");
                using (DatabaseClient client = Eucalypt.dbManager.GetClient())
                {
                    table = client.getTable("SELECT rclr_cost, rclr_reward FROM system_recycler");
                }
                sessionLength = int.Parse(Config.getTableEntry("recycler_session_length"));
                sessionExpireLength = int.Parse(Config.getTableEntry("recycler_session_expirelength"));
                itemMinOwnershipLength = int.Parse(Config.getTableEntry("recycler_minownertime"));
                sessionRewards = new Hashtable();
                recyclerManager.setupString = "I" + Encoding.encodeVL64(itemMinOwnershipLength) + Encoding.encodeVL64(sessionLength) + Encoding.encodeVL64(sessionExpireLength) + Encoding.encodeVL64(table.Rows.Count);
                foreach (DataRow row in table.Rows)
                {
                    catalogueManager.itemTemplate template = catalogueManager.getTemplate(Convert.ToInt32(row["rclr_reward"]));
                    if (template.Sprite != "")
                    {
                        sessionRewards.Add(Convert.ToInt32(row["rclr_cost"]), Convert.ToInt32(row["rclr_reward"]));
                        object setupString = recyclerManager.setupString;
                        recyclerManager.setupString = string.Concat(new object[] { setupString, Encoding.encodeVL64(Convert.ToInt32(row["rclr_cost"])), "H", template.Sprite, Convert.ToChar(2), "H", Encoding.encodeVL64(template.Length), Encoding.encodeVL64(template.Width), Convert.ToChar(2) });
                    }
                }
                Out.WriteLine("Recycler enabled.");
            }
            else
            {
                recyclerManager.setupString = "H";
                Out.WriteLine("Recycler disabled.");
            }
            if (Update)
            {
                Thread.CurrentThread.Abort();
            }
        }

        public static int passedMinutes(int userID)
        {
            try
            {
                TimeSpan span;
                using (DatabaseClient client = Eucalypt.dbManager.GetClient())
                {
                    span = (TimeSpan) (DateTime.Now - DateTime.Parse(client.getString("SELECT session_started FROM users_recycler WHERE userid = '" + userID + "' LIMIT 1")));
                }
                return Convert.ToInt32(span.TotalMinutes);
            }
            catch
            {
                return 0;
            }
        }

        public static bool rewardExists(int itemCount)
        {
            return sessionRewards.ContainsKey(itemCount);
        }

        public static void rewardSession(int userID)
        {
            int templateID = sessionRewardID(userID);
            using (DatabaseClient client = Eucalypt.dbManager.GetClient())
            {
                client.AddParamWithValue("reward", sessionRewardID(userID));
                client.AddParamWithValue("userID", userID);
                client.runQuery("INSERT INTO furniture(tid,ownerid, roomid) VALUES (@reward, @userID, '0')");
            }
            catalogueManager.handlePurchase(templateID, userID, 0, "0", 0, 0);
        }

        public static bool sessionExists(int userID)
        {
            using (DatabaseClient client = Eucalypt.dbManager.GetClient())
            {
                return client.findsResult("SELECT userid FROM users_recycler WHERE userid = '" + userID + "'");
            }
        }

        public static bool sessionReady(int userID)
        {
            if (sessionExists(userID))
            {
                int num = passedMinutes(userID);
                if ((num > sessionLength) & (num < sessionExpireLength))
                {
                    return true;
                }
            }
            return false;
        }

        private static int sessionRewardID(int userID)
        {
            using (DatabaseClient client = Eucalypt.dbManager.GetClient())
            {
                return client.getInt("SELECT session_reward FROM users_recycler WHERE userid = '" + userID + "'");
            }
        }

        public static string sessionString(int userID)
        {
            if (Config.enableRecycler)
            {
                using (DatabaseClient client = Eucalypt.dbManager.GetClient())
                {
                    if (!client.findsResult("SELECT * FROM users_recycler WHERE userid = '" + userID + "'"))
                    {
                        return "H";
                    }
                }
                int num = passedMinutes(userID);
                if (num < sessionLength)
                {
                    return string.Concat(new object[] { "IH", catalogueManager.getTemplate(sessionRewardID(userID)).Sprite, Convert.ToChar(2), Encoding.encodeVL64(sessionLength - num) });
                }
                if (num > sessionLength)
                {
                    return ("JH" + catalogueManager.getTemplate(sessionRewardID(userID)).Sprite + Convert.ToChar(2));
                }
                if (num > sessionExpireLength)
                {
                    return "K";
                }
            }
            return "H";
        }
    }
}