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

namespace BathHouseManagmet.Database;

public class OrderRepository
{
    MySqlConnection connection;

    public OrderRepository(IOptions<DatabaseConnection> connect)
    {
        connection = new MySqlConnection(connect.Value.ConnectionString);
    }

    public List<Order> GetOrders()
    {
        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 \n";
        try
        {
            connection.Open();
            using (var command = new MySqlCommand(sql, connection))
            using (var reader = command.ExecuteReader())
            {
                while (reader.Read())
                {
                    result.Add(new Order
                    {
                        /*
                        Id = reader.GetInt32("id"),
                        ClientId = reader.GetInt32("client_id"),
                        ZoneId =  reader.GetInt32("zone_id"),
                        OrderDate = reader.GetDateTime("order_date"),
                        ServiceId =  reader.GetInt32("service_id"),
                        EmployeeId = reader.GetInt32("employee_id"),
                        DiscountId = reader.GetInt32("discount_id"),
                        FinalPrice = reader.GetInt32("final_price"),
                        */
                        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"),
                        
                    });
                }
            }
            connection.Close();
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
        }
        return result;
    }

    public bool InsertOrder(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
        {
            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();
            }
            connection.Close();
        }
        catch (Exception e)
        {
            connection.Close();
            return false;
        }
        connection.Close();
        return true;
    }

    public bool UpdateOrder(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();
            }
            connection.Close();
        }
        catch (Exception e)
        {
            connection.Close();
            return false;
        }
        connection.Close();
        return true;
    }

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