Il est désormais possible de visualiser l'état du réseau de capteurs

sfeutrie
1 parent 11329db5
Showing 10 changed files with 260 additions and 4 deletions Show diff stats
PFE06/src/main/java/com/PFE/ServerManager/MainController.java
PFE06/src/main/java/com/PFE/ServerManager/SecurityConfig.java
PFE06/src/main/java/com/PFE/ServerManager/UpdateYAML.java
PFE06/src/main/resources/application.properties
PFE06/src/main/resources/templates/all.html
PFE06/src/main/resources/templates/history.html
PFE06/src/main/resources/templates/home.html
PFE06/src/main/resources/templates/registration.html
PFE06/src/main/resources/templates/update.html
PFE06/src/main/resources/templates/upload.html
@@ -12,6 +12,10 @@ import org.springframework.web.servlet.ModelAndView;
 import java.io.*;
 import java.sql.Timestamp;
 import java.text.ParseException;
+import java.time.Duration;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.time.format.DateTimeFormatter;
 import java.util.*;
 import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
@@ -26,7 +30,6 @@ import com.fasterxml.jackson.databind.ObjectMapper;
 import java.text.SimpleDateFormat;
 import java.util.Date;
-import java.util.Locale;
 @Controller
 @MultipartConfig(fileSizeThreshold = 100000000) //à changer, taille max des fichiers
@@ -262,7 +265,6 @@ public class MainController {
     }
-
     @GetMapping(path="/login")
     public ModelAndView login() {
         ModelAndView modelAndView = new ModelAndView();
@@ -274,7 +276,6 @@ public class MainController {
     public ModelAndView getAllUsers() {
         ModelAndView modelAndView = new ModelAndView();
         modelAndView.setViewName("all");
-
         Authentication auth = SecurityContextHolder.getContext().getAuthentication();
         Customer customer = customerRepository.findByEmail(auth.getName());
         modelAndView.addObject("customerName", customer.getEmail().split("@")[0]);
@@ -286,6 +287,85 @@ public class MainController {
         return modelAndView;
     }
+    public static List<ArrayList<String>> getSensorsUsed(List<Node> nodes) {
+        Yaml yaml = new Yaml(new Constructor(UpdateYAML.class));
+        InputStream inputStream = null;
+        List<UpdateYAML> updateYAMLS = new ArrayList<>();
+        List<String> state_sensor = new ArrayList<>();
+        File dir = new File("toflash");
+        if(dir.isDirectory()) {
+            String s[] = dir.list();
+            for (int i = 0; i < s.length; i++) {
+                if(s[i].endsWith("yml.started")) {
+                    state_sensor.add(i,"started");
+                }
+                else{
+                    state_sensor.add(i,"programmed");
+                }
+                try {
+                    inputStream = new FileInputStream(new File("toflash/" + s[i]));
+                    UpdateYAML update = yaml.load(inputStream);
+                    updateYAMLS.add(update);
+                } catch (FileNotFoundException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+        List<ArrayList<String>> table = new ArrayList<>();
+        System.out.println("size = " + updateYAMLS.size());
+        int i=0, j=0, k=0;
+
+        for(Node node : nodes){
+            table.add(new ArrayList<>());
+            for(Sensor sensor : node.getSensors()){
+                for(UpdateYAML update : updateYAMLS) {
+                    for(String sensorUpdate : update.getNodesSplited()){
+                        if(sensor.getName().equals(sensorUpdate)){
+                            DateTimeFormatter formatter_date = DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm");
+                            DateTimeFormatter formatter_time = DateTimeFormatter.ofPattern("HH:mm");
+                            LocalDateTime updateDate = LocalDateTime.parse(update.getDate(),formatter_date);
+                            LocalDateTime now = LocalDateTime.now();
+                            if(state_sensor.get(k).equals("started")){
+                                System.out.println("Time : " + update.getTime());
+                                System.out.println("duration between in minutes " + Duration.between(now,updateDate).toMinutes());
+                                LocalTime duration = LocalTime.parse(update.getTime(),formatter_time);
+                                updateDate = updateDate.plusMinutes(duration.getMinute());
+                                updateDate = updateDate.plusHours(duration.getHour());
+                                table.get(i).add(j,"utilisé (disponible dans " + Duration.between(now,updateDate).toHours() + "h " + (Duration.between(now,updateDate).toMinutes())%60 + "min)");
+                            }
+                            else if(state_sensor.get(k).equals("programmed")){
+                                table.get(i).add(j,"programmé (débute dans " + Duration.between(now,updateDate).toHours() + "h " + (Duration.between(now,updateDate).toMinutes())%60 + "min)");
+                            }
+                        }
+                    }
+                    k++;
+                }
+                k=0;
+                if(table.get(i).size()==j){
+                    System.out.println("fonctionne");
+                    table.get(i).add(j,"disponible");
+                }
+                j++;
+            }
+            j=0;
+            i++;
+        }
+        System.out.println("table : " + table);
+        return table;
+    }
+
+    @GetMapping(path="/history")
+    public ModelAndView displayHistory() {
+        ModelAndView modelAndView = new ModelAndView();
+        modelAndView.setViewName("history");
+        Authentication auth = SecurityContextHolder.getContext().getAuthentication();
+        Customer customer = customerRepository.findByEmail(auth.getName());
+        modelAndView.addObject("customerName", customer.getEmail().split("@")[0]);
+        modelAndView.addObject("customerRole", customer.getRole());
+        modelAndView.addObject("nodes", nodeRepository.findAll());
+        modelAndView.addObject("is_used", getSensorsUsed(nodeRepository.findAll()));
+        return modelAndView;
+    }
     public static String findFile(String filename) {
         File dir = new File("files");
@@ -34,6 +34,7 @@ public class SecurityConfig extends WebSecurityConfigurerAdapter {
         http
                 .authorizeRequests()
                     .antMatchers("/home").hasAnyAuthority("USER","ADMIN")
+                    .antMatchers("/history").hasAnyAuthority("USER","ADMIN")
                     .antMatchers("/registration").hasAuthority("ADMIN")
                     .antMatchers("/config").hasAuthority("ADMIN")
                     .antMatchers("/all").hasAuthority("ADMIN")
@@ -0,0 +1,80 @@
+package com.PFE.ServerManager;
+
+import java.util.HashSet;
+import java.util.Set;
+
+public class UpdateYAML {
+
+    private String date;
+    private String file;
+    private Set<String> nodes;
+    private String exp_id;
+    private String name;
+    private String time;
+    private String arch;
+    private String dir;
+
+    public void setDate(String date) {
+        this.date = date;
+    }
+    public String getDate() {
+        return date;
+    }
+
+    public void setFile(String file) {
+        this.file = file;
+    }
+    public String getFile() {
+        return file;
+    }
+
+    public void setNodes(Set<String> nodes) {
+        this.nodes = nodes;
+    }
+    public Set<String> getNodes() {
+        return nodes;
+    }
+    public Set<String> getNodesSplited() {
+        Set<String> nodesSplited = new HashSet<>();
+        for(String node : nodes){
+            nodesSplited.add(node.split("@")[0]);
+        }
+        System.out.println(nodesSplited);
+        return nodesSplited;
+    }
+
+    public void setArch(String arch) {
+        this.arch = arch;
+    }
+    public String getArch() {
+        return arch;
+    }
+
+    public void setExp_id(String exp_id) {
+        this.exp_id = exp_id;
+    }
+    public String getExp_id() {
+        return exp_id;
+    }
+
+    public void setDir(String dir) {
+        this.dir = dir;
+    }
+    public String getDir() {
+        return dir;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+    public String getName() {
+        return name;
+    }
+
+    public void setTime(String time) {
+        this.time = time;
+    }
+    public String getTime() {
+        return time;
+    }
+}
@@ -14,7 +14,7 @@ spring.datasource.username=postgres
 spring.datasource.password=glopglop
 # montre les communications JPA avec la BDD
-spring.jpa.show-sql = true
+# spring.jpa.show-sql = true
 # exécute le fichier data.sql pour préciser le role ADMIN
 spring.datasource.initialization-mode=always
@@ -23,9 +23,11 @@
                             <a class="nav-item nav-link" th:href="@{/registration}">Enregistrer des utilisateurs</a>
                             <a class="nav-item nav-link active" th:href="@{/all}">Liste des utilisateurs</a>
                             <a class="nav-item nav-link" th:href="@{/update}">Paramétrer une mise à jour</a>
+                            <a class="nav-item nav-link" th:href="@{/history}">Etat du réseau</a>
                         </div>
                         <div th:remove="tag" th:case="'USER'">
                             <a class="nav-item nav-link" th:href="@{/update}">Paramétrer une mise à jour</a>
+                            <a class="nav-item nav-link" th:href="@{/history}">Etat du réseau</a>
                         </div>
                     </div>
                 </div>
@@ -0,0 +1,84 @@
+<!DOCTYPE html>
+<html xmlns:th="http://www.thymeleaf.org">
+<head>
+    <meta charset="utf-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1, shrink-to-fit=no">
+    <link rel="stylesheet" th:href="@{/css/all.css}">
+    <link rel="stylesheet" href="https://stackpath.bootstrapcdn.com/bootstrap/4.1.3/css/bootstrap.min.css" integrity="sha384-MCw98/SFnGE8fJT3GXwEOngsV7Zt27NXFoaoApmYm81iuXoPkFOJwJ8ERdknLPMO" crossorigin="anonymous">
+    <title>Etat actuel du réseau</title>
+</head>
+<body>
+<!-- NAV BAR -->
+<nav class="navbar navbar-expand-lg navbar-dark bg-dark">
+    <div class="container">
+        <a th:href="@{/home}"><span class="navbar-brand"><img style="max-width:32px;" src="/pfelogo.png"></span></a>
+        <button class="navbar-toggler" type="button" data-toggle="collapse" data-target="#navbarNavAltMarkup" aria-controls="navbarNavAltMarkup" aria-expanded="false" aria-label="Toggle navigation">
+            <span class="navbar-toggler-icon"></span>
+        </button>
+        <div class="collapse navbar-collapse" id="navbarNavAltMarkup">
+            <div class="navbar-nav mr-auto">
+                <a class="nav-item nav-link" th:href="@{/upload}">Uploader un fichier</a>
+                <div th:remove="tag" th:switch="${customerRole}">
+                    <div th:remove="tag" th:case="'ADMIN'">
+                        <a class="nav-item nav-link" th:href="@{/registration}">Enregistrer des utilisateurs</a>
+                        <a class="nav-item nav-link" th:href="@{/all}">Liste des utilisateurs</a>
+                        <a class="nav-item nav-link" th:href="@{/update}">Paramétrer une mise à jour</a>
+                        <a class="nav-item nav-link active" th:href="@{/history}">Etat du réseau</a>
+                    </div>
+                    <div th:remove="tag" th:case="'USER'">
+                        <a class="nav-item nav-link" th:href="@{/update}">Paramétrer une mise à jour</a>
+                        <a class="nav-item nav-link active" th:href="@{/history}">Etat du réseau</a>
+                    </div>
+                </div>
+            </div>
+        </div>
+        <div class="collapse navbar-collapse ml-3" id="navbarNavAltMarkup2" >
+            <div class="navbar-nav ml-auto">
+                <a class="nav-item nav-link btn btn-danger active" th:href="@{/logout}">Déconnexion</a>
+            </div>
+        </div>
+    </div>
+</nav>
+
+
+<!-- TABLE PART -->
+
+<div class="container">
+    <h1 style="margin-bottom:50px; margin-top:50px; border-bottom:1px solid #CCC; padding-bottom:20px;">Réseau</h1>
+    <table class="table table-striped table-bordered">
+        <tr>
+            <th scope="col">Nom</th>
+            <th scope="col">IP</th>
+            <th scope="col">Architecture</th>
+            <th scope="col">Capteurs</th>
+            <th scope="col">Etat</th>
+        </tr>
+        <tr th:each="prod,status : ${nodes}">
+            <td th:text="${prod.getName()}">Team</td>
+            <td th:text="${prod.getIp()}">IP</td>
+            <td th:text="${prod.getArch()}">Arch</td>
+            <td>
+                <div  th:each="sensor : ${prod.getSensors()}" th:utext="${sensor.getName()}"></div>
+            </td>
+            <td>
+                <div th:each="value : ${is_used[status.index]}">
+                    <div th:utext="${value}"></div>
+                    <!--<div th:if="${value}==1">utilisé</div>
+                    <div th:if="${value}==0">disponible</div>-->
+                </div>
+            </td>
+            <!--<td>
+                <div  th:each="sensor : ${prod.getSensors()}">
+                    <div th:each="update : ${updates}" th:if="${update.getNodesSplited().contains(sensor.getName())}">utilisé</div>
+                </div>
+            </td>-->
+        </tr>
+    </table>
+</div>
+
+<script src="https://cdn.jsdelivr.net/npm/vue@2.5.16/dist/vue.js"></script>
+<script src="https://code.jquery.com/jquery-3.3.1.slim.min.js" integrity="sha384-q8i/X+965DzO0rT7abK41JStQIAqVgRVzpbzo5smXKp4YfRvH+8abtTE1Pi6jizo" crossorigin="anonymous"></script>
+<script src="https://cdnjs.cloudflare.com/ajax/libs/popper.js/1.14.3/umd/popper.min.js" integrity="sha384-ZMP7rVo3mIykV+2+9J3UJ46jBk0WLaUAdn689aCwoqbBJiSnjAK/l8WvCWPIPm49" crossorigin="anonymous"></script>
+<script src="https://stackpath.bootstrapcdn.com/bootstrap/4.1.3/js/bootstrap.min.js" integrity="sha384-ChfqqxuZUCnJSK3+MXmPNIyE6ZbWh2IMqE241rYiqJxyMiZ6OW/JmZQ5stwEULTy" crossorigin="anonymous"></script>
+</body>
+</html>
@@ -28,9 +28,11 @@
                             <a class="nav-item nav-link" th:href="@{/registration}">Enregistrer des utilisateurs</a>
                             <a class="nav-item nav-link" th:href="@{/all}">Liste des utilisateurs</a>
                             <a class="nav-item nav-link" th:href="@{/update}">Paramétrer une mise à jour</a>
+                            <a class="nav-item nav-link" th:href="@{/history}">Etat du réseau</a>
                         </div>
                         <div th:remove="tag" th:case="'USER'">
                             <a class="nav-item nav-link" th:href="@{/update}">Paramétrer une mise à jour</a>
+                            <a class="nav-item nav-link" th:href="@{/history}">Etat du réseau</a>
                         </div>
                     </div>
                 </div>
@@ -22,9 +22,11 @@
                             <a class="nav-item nav-link active" th:href="@{/registration}">Enregistrer des utilisateurs</a>
                             <a class="nav-item nav-link" th:href="@{/all}">Liste des utilisateurs</a>
                             <a class="nav-item nav-link" th:href="@{/update}">Paramétrer une mise à jour</a>
+                            <a class="nav-item nav-link" th:href="@{/history}">Etat du réseau</a>
                         </div>
                         <div th:remove="tag" th:case="'USER'">
                             <a class="nav-item nav-link" th:href="@{/update}">Paramétrer une mise à jour</a>
+                            <a class="nav-item nav-link" th:href="@{/history}">Etat du réseau</a>
                         </div>
                     </div>
                 </div>
@@ -28,9 +28,11 @@
                             <a class="nav-item nav-link" th:href="@{/registration}">Enregistrer des utilisateurs</a>
                             <a class="nav-item nav-link" th:href="@{/all}">Liste des utilisateurs</a>
                             <a class="nav-item nav-link active" th:href="@{/update}">Paramétrer une mise à jour</a>
+                            <a class="nav-item nav-link" th:href="@{/history}">Etat du réseau</a>
                         </div>
                         <div th:remove="tag" th:case="'USER'">
                             <a class="nav-item nav-link" th:href="@{/update}">Paramétrer une mise à jour</a>
+                            <a class="nav-item nav-link" th:href="@{/history}">Etat du réseau</a>
                         </div>
                     </div>
                 </div>
@@ -128,6 +130,7 @@ nodes:
         <button id="allDone" type="button" class="btn btn-primary">Terminer</button>
         <button id="nextNode" type="button" class="btn btn-secondary">></button>
+
         <!-- The Modal -->
         <div class="modal fade" id="networkDisplay">
             <div class="modal-dialog modal-dialog-centered">
@@ -28,9 +28,11 @@
                             <a class="nav-item nav-link" th:href="@{/registration}">Enregistrer des utilisateurs</a>
                             <a class="nav-item nav-link" th:href="@{/all}">Liste des utilisateurs</a>
                             <a class="nav-item nav-link" th:href="@{/update}">Paramétrer une mise à jour</a>
+                            <a class="nav-item nav-link" th:href="@{/history}">Etat du réseau</a>
                         </div>
                         <div th:remove="tag" th:case="'USER'">
                             <a class="nav-item nav-link" th:href="@{/update}">Paramétrer une mise à jour</a>
+                            <a class="nav-item nav-link" th:href="@{/history}">Etat du réseau</a>
                         </div>
                     </div>
                 </div>