ntr-interferences/src/main/java/fr/ntr/AccessPoint.java

package fr.ntr;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.List;
import java.util.Random;

import fr.ntr.scheduler.Scheduler;

public class AccessPoint {

    private Cell cell1;
    private Cell cell2;
    private List<User> users;
    private FileOutputStream outputDataFile;

    public AccessPoint(Cell cell1, Cell cell2){
        this.cell1 = cell1;
        this.cell2 = cell2;
    }

    /**
     * Lancer la simulation
     * @param duration
     */
    public void startSimulation(int duration) {
        /*
        try{
            Files.deleteIfExists(Paths.get("export", this.users.size() + ".csv"));
            new File("export").mkdir();
            this.outputDataFile = new FileOutputStream("export" + File.separator + this.users.size() + ".csv", true);
            outputDataFile.write("tick;x;y;user;bandwidth;\n".getBytes());
        } catch(IOException e) {
            System.err.println(e.getClass().getSimpleName() + " : " + e.getMessage());
            System.exit(1);
            return;
        }
        */
        for (int ticks = 0; ticks < duration; ++ticks) {
            // Simulation
            cell1.reset();
            cell2.reset();
            cell1.updateBandwidth(ticks);
            cell2.updateBandwidth(ticks);
            cell1.schedule();
            cell2.schedule();

            //simulation des interférences
            computeInterference();

            // traite les données et les enregistre dans un fichier

          /*  try {
                analyseData(ticks);
            } catch (IOException e) {
                System.out.println("Can't export data");
            }*/

        }
    }

    public void computeInterference () {
        ResourceBlock[][] frameCell1 = cell1.getFrame();
        ResourceBlock[][] frameCell2 = cell2.getFrame();

        for (int k = 0; k > frameCell1.length; k++ ) {
            for (int l = 0; l < frameCell1[k].length; l++) {
                //interférences si les deux cellules parlent au même UE sur le même time slot
                User user1 = frameCell1[k][l].getUser();
                User user2 = frameCell2[k][l].getUser();
                if (user1 == user2) {
                    double bandwidth1 = frameCell1[k][l].getBandwidth();
                    double bandwidth2 = frameCell2[k][l].getBandwidth();
                    //User proche
                    if (user1.getDistance() > 200d) {
                        frameCell1[k][l].setBandwidth(bandwidth1 / 2);
                        frameCell2[k][l].setBandwidth(bandwidth2 / 2);
                    }
                    //User loin
                    else {
                        frameCell1[k][l].setBandwidth(bandwidth1 / 4);
                        frameCell2[k][l].setBandwidth(bandwidth2 / 4);
                    }
                }
            }
        }
    }
/*
    private void analyseData(int tick) throws IOException {
        for(int i = 0; i < cell1.getFrame().length; i++) {
            for(int j = 0; j < cell1.getFrame()[i].length; j++) {
                ResourceBlock ur = cell1.getFrame()[i][j];
                if(ur.getUser() != null) {
                    String data = (tick + ";" + i + ";" + j + ";" + this.users.indexOf(ur.getUser()) + ";" + ur.getBandwidth() + ";\n");
                    try{
                        outputDataFile.write(data.getBytes());
                    }catch(IOException e){
                        System.err.println("Cannot write the data in the output file");
                        System.exit(1);
                        return;
                    }
                }
            }
        }
    }
 */
}