package orm;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;

import entities.Cliente;
import entities.Impiegato;
import entities.Persona;

public class Azienda implements IAzienda
{
	private String path;

	public Azienda(String path)
	{
		super();
		this.path = path;
	}

	public ArrayList<Cliente> loaderClienti(String condizioneextra)
	{
		ArrayList<Cliente> ris = new ArrayList<Cliente>();
		String user = "root";
		String password = "root";
		Connection conn = null;
		Statement s = null;
		try
		{
			Class.forName("com.mysql.jdbc.Driver");

			conn = DriverManager.getConnection(path,user,password);

			s = conn.createStatement();
			String sql;
			sql = "Select * from ";
			ResultSet rs = null;

			rs = s.executeQuery(sql+"vistaclienti "+condizioneextra);
			while(rs.next())
			{
				int id = rs.getInt("id");
				String nome = rs.getString("nome");
				String cognome = rs.getString("cognome");
				String nascita = rs.getString("nascita");
				String email = rs.getString("email");
				String ntel = rs.getString("ntel");
				String indirizzo = rs.getString("indirizzo");
				int fatturatoAnnuo = rs.getInt("fatturatoannuo");
				String modPagamento = rs.getString("modpagamento");

				Cliente c = new Cliente(nome,cognome,nascita,email,ntel,indirizzo,fatturatoAnnuo,modPagamento,loaderReferenti("where referentedi="+id));

				ris.add(c);
			}
			rs.close();
			conn.close();
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
		return ris;
	}

	public ArrayList<Persona> loaderReferenti(String condizioneextra)
	{
		ArrayList<Persona> ris = new ArrayList<Persona>();
		String user = "root";
		String password = "root";
		Connection conn = null;
		Statement s = null;
		try
		{
			Class.forName("com.mysql.jdbc.Driver");

			conn = DriverManager.getConnection(path,user,password);

			s = conn.createStatement();
			String sql;
			sql = "Select * from ";
			ResultSet rs = null;

			rs = s.executeQuery(sql+"vistareferenti "+condizioneextra);
			while(rs.next())
			{
				int id = rs.getInt("id");
				String nome = rs.getString("nome");
				String cognome = rs.getString("cognome");
				String nascita = rs.getString("nascita");
				String email = rs.getString("email");
				String ntel = rs.getString("ntel");
				String indirizzo = rs.getString("indirizzo");

				Persona p = new Persona(nome,cognome,nascita,email,ntel,indirizzo);

				ris.add(p);
			}
			rs.close();
			conn.close();
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
		return ris;
	}

	public ArrayList<Impiegato> loaderImpiegati(String condizioneextra)
	{
		ArrayList<Impiegato> ris = new ArrayList<Impiegato>();
		String user = "root";
		String password = "root";
		Connection conn = null;
		Statement s = null;
		Statement s1 = null;

		try
		{
			Class.forName("com.mysql.jdbc.Driver");

			conn = DriverManager.getConnection(path,user,password);

			s = conn.createStatement();
			String sql;
			sql = "Select * from ";
			ResultSet rs = null;
			ResultSet rs1 = null;
			s1 = conn.createStatement();
			ArrayList<Impiegato> temp = new ArrayList<Impiegato>();
			rs = s.executeQuery(sql+"vistaimpiegati "+condizioneextra);
			while(rs.next())
			{
				int id = rs.getInt("id");
				String nome = rs.getString("nome");
				String cognome = rs.getString("cognome");
				String nascita = rs.getString("nascita");
				String email = rs.getString("email");
				String ntel = rs.getString("ntel");
				String indirizzo = rs.getString("indirizzo");
				int annidiservizio = rs.getInt("AnniServizio");
				String mansione = rs.getString("modpagamento");

				rs1 = s1.executeQuery(sql+"vistaimpiegati where idboss ="+id);
				while(rs1.next())
				{

					int id1 = rs.getInt("id");
					String nome1 = rs.getString("nome");
					String cognome1 = rs.getString("cognome");
					String nascita1 = rs.getString("nascita");
					String email1 = rs.getString("email");
					String ntel1 = rs.getString("ntel");
					String indirizzo1 = rs.getString("indirizzo");
					int annidiservizio1 = rs.getInt("AnniServizio");
					String mansione1 = rs.getString("modpagamento");
					Impiegato prova = new Impiegato(nome,cognome,nascita,email,ntel,indirizzo,annidiservizio,mansione);
					temp.add(prova);
				}

				Impiegato i = new Impiegato(nome,cognome,nascita,email,ntel,indirizzo,annidiservizio,mansione, temp);

				ris.add(i);
			}
			rs.close();
			conn.close();
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
		return ris;
	}
	public ArrayList<Impiegato> impiegati()
	{
		ArrayList<Impiegato> ris = new ArrayList<Impiegato>();

		for(Impiegato i : loaderImpiegati(""))
			ris.add(i);
		return ris;
	}

	@Override
	public ArrayList<Impiegato> teamLeader()
	{
		ArrayList<Impiegato> ris = new ArrayList<Impiegato>();

		for(Impiegato i : loaderImpiegati(""))
			if(i.teamLeader())
				ris.add(i);
		return ris;
	}

	@Override
	public ArrayList<Impiegato> impiegati(String mansione)
	{
		ArrayList<Impiegato> ris = new ArrayList<Impiegato>();
		String s = "where mansione=";

		for(Impiegato i : loaderImpiegati(s+mansione))
				ris.add(i);
		return ris;
	}
}