using System;
using System.Collections.Generic;
using BathHouseManagmet.Models;
using BathHouseManagmet.Models.Database;
using BathHouseManagmet.Models.Interfaces;
using Microsoft.Extensions.Options;
using MySqlConnector;

namespace BathHouseManagmet.Database;

public class OrderRepository : BaseRepository<Order>, IDisposable
{
    public OrderRepository()
    {
        OpenConnection();
    }

    public override List<Order> GetPage(int pageNumber, int pageSize)
    {
        List<Order> result = new();
        string sql =
            "select o.id as oid, o.client_id as ocid, o.employee_id as eid, o.discount_id as did, o.service_id as sid, o.zone_id as zid, c.name as cname, c.surname as csurname, o.order_time as otime, e.name as ename, e.surname as esurname, d.name as dname, s.name as sname, z.name as zname from `order` o join client c on o.client_id = c.id join employee e on o.employee_id = e.id join discount d on o.discount_id = d.id join service s on o.service_id = s.id join zone z on  o.zone_id = z.id limit @limit offset @offset";
        try
        {
            using var command = new MySqlCommand(sql, connection);
            command.Parameters.AddWithValue("@limit", pageNumber);
            command.Parameters.AddWithValue("@offset", pageNumber * pageSize);
            using var reader = command.ExecuteReader();
            while (reader.Read())
            {
                result.Add(new Order
                {

                    Client = new Client()
                    {
                        Id = reader.GetInt32("ocid"),
                        Name = reader.GetString("cname"),
                        Surname = reader.GetString("csurname"),
                    },

                    Employee = new Employee()
                    {
                        Id = reader.GetInt32("eid"),
                        Name = reader.GetString("ename"),
                        Surname = reader.GetString("esurname"),
                    },

                    Discount = new Discount()
                    {
                        Id = reader.GetInt32("did"),
                        Name = reader.GetString("dname"),
                    },

                    Zone = new Zone()
                    {
                        Id = reader.GetInt32("zid"),
                        Name = reader.GetString("zname"),
                    },

                    Service = new Service()
                    {
                        Id = reader.GetInt32("sid"),
                        Name = reader.GetString("sname"),
                    },
                    FinalPrice = reader.GetInt32("final_price"),
                    OrderDate = reader.GetDateTime("order_date"),
                    Id = reader.GetInt32("oid"),

                });
            }
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
        }

        return result;
    }

    public override bool Add(Order order)
    {
        string sql =
            "insert into `order` (`id`, `client_id`, `zone_id`, `order_date`, `service_id`, `employee_id`, `discount_id`, `final_price`) values (0, @client_id, @client_id, @zone_id, @order_date, @service_id, @employee_id, @discount_id, @final_price)";
        try
        {
            using (var command = new MySqlCommand(sql, connection))
            {
                command.Parameters.AddWithValue("@client_id", order.ClientId);
                command.Parameters.AddWithValue("@zone_id", order.ZoneId);
                command.Parameters.AddWithValue("@order_date", order.OrderDate);
                command.Parameters.AddWithValue("@service_id", order.ServiceId);
                command.Parameters.AddWithValue("@employee_id", order.EmployeeId);
                command.Parameters.AddWithValue("@discount_id", order.DiscountId);
                command.Parameters.AddWithValue("@final_price", order.FinalPrice);
                command.ExecuteNonQuery();
            }
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
            return false;
        }

        return true;
    }

    public override bool Update(Order order)
    {
        string sql =
            "update `order` set client_id = @client_id, zone_id = @zone_id, order_date = @order_date, service_id = @service_id, employee_id = @employee_id, discount_id = @discount_id, final_price = @final_price";
        try
        {
            connection.Open();
            using (var command = new MySqlCommand(sql, connection))
            {
                command.Parameters.AddWithValue("@client_id", order.ClientId);
                command.Parameters.AddWithValue("@zone_id", order.ZoneId);
                command.Parameters.AddWithValue("@order_date", order.OrderDate);
                command.Parameters.AddWithValue("@service_id", order.ServiceId);
                command.Parameters.AddWithValue("@employee_id", order.EmployeeId);
                command.Parameters.AddWithValue("@discount_id", order.DiscountId);
                command.Parameters.AddWithValue("@final_price", order.FinalPrice);
                command.ExecuteNonQuery();
            }
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
            return false;
        }

        return true;
    }

    public override bool Delete(Order order)
    {
        string sql = "delete from `order` where `id` = " + order.Id;
        try
        {
            using (var command = new MySqlCommand(sql, connection))
            {
                command.ExecuteNonQuery();
            }
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
            return false;
        }

        return true;
    }

    public int GetRowsCount()
    {
        string sql = "select count(id) from `order`";
        try
        {
            using var mc = new MySqlCommand(sql, connection);
            return Convert.ToInt32(mc.ExecuteScalar());
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
            return 0;
        }
    }
    
    public void Dispose()
    {
        CloseConnection();
        base.Dispose();
    }
}