import java.util.ArrayList;
import java.util.Scanner;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;

public class Strategia1 {
    int max;
    int zakres;
    int p;
    int ilozap = 0;
    int migracja = 0;
    int s ;
    int r = 0;
    int iloscodwolan = 0;
    ConcurrentHashMap<Integer, Integer> zlecenia = new ConcurrentHashMap<Integer, Integer>();
    ConcurrentHashMap<Integer, Integer> procobc = new ConcurrentHashMap<Integer, Integer>();
    ConcurrentHashMap<Integer, Integer> przypisane = new ConcurrentHashMap<Integer, Integer>();
    Scanner sc = new Scanner(System.in);

    public void Generowanie() throws IOException {
        int czas;
        int obc;
        System.out.println("Podaj maksymalny czas wykonania się procesu");
        int a = sc.nextInt();
        System.out.println("Podaj maksymalne obciążenie  dla jednego procesu");
        int b = sc.nextInt();
        System.out.println("Podaj ilość procesów");
        int i = 0;
        int c = sc.nextInt();
        System.out.println("Podaj ilość procesorów");
        int d = sc.nextInt();
        System.out.println("Podaj maksymalne obciążenie dla procesora");
        max = sc.nextInt();
        System.out.println("Podaj maksymalną ilośc zapytań");
        zakres = sc.nextInt();
        System.out.println("Podaj progową wartość obciążenia ");
        p = sc.nextInt();
        System.out.println("Podaj minimalną wartość obciążenia (r z zadania) ");
        r = sc.nextInt();
        do {
            if (b < c) {
                System.out.println("Potrzebujesz więcej kluczy niż zgłoszeń");
            }
            czas = (int) (Math.random() * a);
            obc = (int) (Math.random() * b);
            if (!zlecenia.containsKey(obc)) {
                zlecenia.put(obc, czas);
                i++;
            }
            for (int z = 0; z < d; z++) {
                procobc.put(z, 0);
            }
        } while (i < c);
        Wypisz();
        System.out.println("Lista zleceń" + zlecenia);
        System.out.println("Procesory" + procobc);
    }

    public void Wypisz() throws IOException {
        Set keys = zlecenia.keySet();
        FileWriter f = new FileWriter("C:/Users/Jarema/Desktop/PWR/angie.txt");
        BufferedWriter abba = new BufferedWriter(f);
        for (Object o : keys) {
            abba.write((int) o + ";" + zlecenia.get(o) + ";"
                    + (procobc.size() - 1) + ";" + p + ";" + max + ";" + r + ";");
            abba.newLine();
        }
        abba.write("Koniec");
        abba.close();
    }

    public void WypiszDane() throws IOException {
        FileWriter f = new FileWriter("C:/Users/Jarema/Desktop/PWR/Dane.txt");
        BufferedWriter abba = new BufferedWriter(f);
            abba.write(ilozap+ ";" + migracja + ";"
                    + s);
            abba.newLine();
        abba.write("Koniec");
        abba.close();
    }

    public void Strat1() throws IOException {
        s = OdchŚred();
        int calka = 0;
        int kontrolka = 0; // ilośc zapytań na dany proces
        Set keys = zlecenia.keySet();
        Object x = 1;
        System.out.println(max);
        do {
            for (Object o : keys) {
                if ((int) (Math.random() * 10) > 5) {
                    boolean przydzielony = false;
                    if (!przypisane.containsKey(o)) {
                        do {

                            kontrolka++;
                            ilozap++;
                            int z = (int) (Math.random() * procobc.size());

                            if ((procobc.get(z) + (int) o) < max) {

                                migracja++;
                                System.out.println("Procesowi " + o
                                        + " przydzielono miejsce na " + z);
                                procobc.put((int) z, procobc.get(z)
                                        + (int) zlecenia.get(o));
                                przypisane.put((Integer) o, z);
                                przydzielony = true;
                                calka++;
                            }
                            if (kontrolka > zakres && procobc.get(z) < max) {

                                System.out
                                        .println("Procesowi "
                                                + o
                                                + " przydzielono miejsce na "
                                                + x
                                                + " Albowiem limit zapytań przekroczonym był");
                                procobc.put((int) z, procobc.get(z)
                                        + (int) zlecenia.get(o));
                                przypisane.put((Integer) o, z);
                                przydzielony = true;
                                calka++;
                            }

                            if (kontrolka >= procobc.size()) {
                                System.out.println("Procesowi " + o
                                        + " przydzielono miejsce na " + x
                                        + " z powodu zapchania reszty");
                                procobc.put((int) z, procobc.get(z) + (int) o);
                                przypisane.put((Integer) o, z);
                                przydzielony = true;
                                calka++;
                            }
                            if (Przeciążone()){
                                break;
                            }
                        } while (przydzielony == false);
                    }

                    kontrolka = 0;
                }

                if ((int) o <= calka && przypisane.get(o) != null) {
                    System.out.println("Proces " + o + " Dotarł do końca ");
                    int a = procobc.get(przypisane.get(o)) - zlecenia.get(o);
                    procobc.put(przypisane.get(o), a);
                    if (!przypisane.contains(o)) {
                        procobc.put(przypisane.get(o), 0);
                    }
                    zlecenia.remove(o);
                    przypisane.remove(o);
                }

                System.out.println("Lista zleceń" + zlecenia);
                System.out.println("Procesory" + procobc);
                System.out.println("Przypisania " + przypisane);
            }
            calka++;
        } while (ToJużJestKoniec() == false);
        System.out
                .println("Podsumowanie : Odchylenie wartości od tej z podpunktu A wynosi 0,zapytania o obciążenie "
                        + ilozap);
        System.out.println("Ilość migracji " + migracja
                + " a średnie obciążenie procesora to  " + s);
        WypiszDane();
    }
    public boolean Przeciążone(){
        Set keys = procobc.keySet();
        for (Object o : keys) {
            if (procobc.get(o) < max) {
                return false;
            }
        }
        return true;
    }
    public int DajZapytania(){
        return ilozap;
    }
    public int DajMigracje(){
        return migracja;
    }
    public int DajSrednia(){
        return s;
    }


    public int Obciazenie() {
        Set keys = zlecenia.keySet();
        int suma = 0;
        for (Object o : keys) {
            suma += zlecenia.get(o);
        }
        return suma;
    }

    public int OdchŚred() {
        return (Obciazenie() / procobc.size());
    }

    public boolean ToJużJestKoniec() {
        Set keys = zlecenia.keySet();
        for (Object o : keys) {
            if (zlecenia.get(o) > 0) {
                return false;
            }
        }
        return true;
    }

    public void DajPorównanie() throws IOException{
        Strat1();
        Strategia2 q = new Strategia2();
        q.Ska();
        Strategia3 w = new Strategia3();
        w.Ska();
        System.out
        .println("Podsumowanie 1: Odchylenie wartości od tej z podpunktu A wynosi 0,zapytania o obciążenie "
                + DajZapytania());
System.out.println("Ilość migracji " + DajMigracje()
        + " a średnie obciążenie procesora to  " + DajSrednia());

System.out.println("Podsumowanie 2: zapytania o obciążenie " + q.DajZapytania()
        + " (zmiana " + (ilozap - q.DajZapytania()) + " względem A)");
System.out.println("Ilość migracji " +q.DajMigracje()
        + (" zmiana " + (migracja - q.DajMigracje()) + " względem A")
        + " a średnie obciążenie procesora to  " + w.DajSrednia()
        + (" zmiana " + (s - q.DajSrednia() + " względem A")));

System.out.println("Podsumowanie 3: zapytania o obciążenie " + q.DajZapytania()
        + " (zmiana " + (ilozap - w.DajZapytania()) + " względem A)");
System.out.println("Ilość migracji " +w.DajMigracje()
        + (" zmiana " + (migracja - w.DajMigracje()) + " względem A")
        + " a średnie obciążenie procesora to  " + w.DajSrednia()
        + (" zmiana " + (s - w.DajSrednia()) + " względem A"));
    }

    public void menu() throws IOException {
        boolean check = false;
        while (check == false) {
            System.out.println("[1] Podaj dane");
            System.out.println("[2] Strategia 1");
            System.out.println("[3] Strategia 2");
            System.out.println("[4] Strategia 3");
            System.out.println("[5] Porównanie");
            int a = sc.nextInt();
            switch (a) {
            case 1:
                Generowanie();
                break;
            case 2:
                Strat1();
                break;
            case 3:
                Strategia2 c = new Strategia2();
                c.Ska();
                break;
            case 4:
                Strategia3 d = new Strategia3();
                d.Ska();
                break;
            case 5:
                DajPorównanie();
                break;
            }
        }
    }

    public static void main(String[] args) throws IOException {
        Strategia1 a = new Strategia1();
        a.menu();
    }
}