MAJ du ClientMQTT.py Version "finale" avec gestion des périodes

Code/Python/AM107/AM107-12/2024-11-22_14-58-32

@@ -0,0 +1 @@
+{22.1, 37.5, 2199}

Code/Python/AM107/AM107-13/2024-11-22_14-52-48

@@ -0,0 +1 @@
+{20, 47.5, 1678}

Code/Python/AM107/AM107-14/2024-11-22_14-50-11

@@ -0,0 +1 @@
+{19.4, 51.5, 1407}

Code/Python/AM107/AM107-15/2024-11-22_14-46-39

@@ -0,0 +1 @@
+{17.9, 50.5, 876}

Code/Python/AM107/AM107-16/2024-11-22_14-51-50

@@ -0,0 +1 @@
+{20.2, 48, 866}

Code/Python/AM107/AM107-17/2024-11-22_14-45-39

@@ -0,0 +1 @@
+{21.7, 52.5, 2070}

Code/Python/AM107/AM107-18/2024-11-22_14-53-48

@@ -0,0 +1 @@
+{18.3, 56, 1406}

Code/Python/AM107/AM107-2/2024-11-22_14-49-48

@@ -0,0 +1 @@
+{21.9, 48, 1252}

Code/Python/AM107/AM107-20/2024-11-22_14-45-39

@@ -0,0 +1 @@
+{20.1, 47, 936}

Code/Python/AM107/AM107-22/2024-11-22_14-53-17

@@ -0,0 +1 @@
+{21.6, 41, 1097}

Code/Python/AM107/AM107-23/2024-11-22_14-51-17

@@ -0,0 +1 @@
+{19.9, 51.5, 1424}

Code/Python/AM107/AM107-24/2024-11-22_14-49-18

@@ -0,0 +1 @@
+{20.1, 48, 877}

Code/Python/AM107/AM107-26/2024-11-22_14-44-50

@@ -0,0 +1 @@
+{21.6, 39.5, 889}

Code/Python/AM107/AM107-27/2024-11-22_14-50-47

@@ -0,0 +1 @@
+{22.5, 43, 1228}

Code/Python/AM107/AM107-28/2024-11-22_14-56-18

@@ -0,0 +1 @@
+{19.5, 39, 469}

Code/Python/AM107/AM107-29/2024-11-22_14-53-48

@@ -0,0 +1 @@
+{21.1, 42, 1192}

Code/Python/AM107/AM107-3/2024-11-22_14-53-08

@@ -0,0 +1 @@
+{22.1, 47, 1361}

Code/Python/AM107/AM107-30/2024-11-22_14-47-20

@@ -0,0 +1 @@
+{20.7, 39.5, 924}

Code/Python/AM107/AM107-31/2024-11-22_14-48-47

@@ -0,0 +1 @@
+{19.1, 39, 518}

Code/Python/AM107/AM107-31/2024-11-22_15-08-49

@@ -0,0 +1 @@
+{19.7, 39, 564}

Code/Python/AM107/AM107-32/2024-11-22_14-49-46

@@ -0,0 +1 @@
+{20.7, 40, 639}

Code/Python/AM107/AM107-36/2024-11-22_14-50-47

@@ -0,0 +1 @@
+{20.7, 42, 1047}

Code/Python/AM107/AM107-37/2024-11-22_14-49-16

@@ -0,0 +1 @@
+{23.2, 33.5, 579}

Code/Python/AM107/AM107-38/2024-11-22_14-47-48

@@ -0,0 +1 @@
+{19.8, 43.5, 1016}

Code/Python/AM107/AM107-39/2024-11-22_14-54-12

@@ -0,0 +1 @@
+{21.3, 39.5, 1108}

Code/Python/AM107/AM107-4/2024-11-22_14-51-37

@@ -0,0 +1 @@
+{22.5, 47, 1924}

Code/Python/AM107/AM107-41/2024-11-22_14-48-47

@@ -0,0 +1 @@
+{20.3, 38, 547}

Code/Python/AM107/AM107-41/2024-11-22_15-08-50

@@ -0,0 +1 @@
+{20.3, 37.5, 538}

Code/Python/AM107/AM107-42/2024-11-22_11-18-06

@@ -0,0 +1 @@
+{19.7, 42, 441}

Code/Python/AM107/AM107-42/2024-11-22_14-58-07

@@ -0,0 +1 @@
+{21.2, 36.5, 456}

Code/Python/AM107/AM107-43/2024-11-22_14-52-15

@@ -0,0 +1 @@
+{22.2, 39.5, 514}

Code/Python/AM107/AM107-45/2024-11-22_14-51-21

@@ -0,0 +1 @@
+{14.9, 49, 443}

Code/Python/AM107/AM107-46/2024-11-22_14-51-19

@@ -0,0 +1 @@
+{20.5, 49.5, 1292}

Code/Python/AM107/AM107-47/2024-11-22_14-52-49

@@ -0,0 +1 @@
+{48.9, 45.5, 790}

Code/Python/AM107/AM107-49/2024-11-22_14-49-49

@@ -0,0 +1 @@
+{19.6, 41, 683}

Code/Python/AM107/AM107-5/2024-11-22_14-51-08

@@ -0,0 +1 @@
+{20.2, 50.5, 1395}

Code/Python/AM107/AM107-50/2024-11-22_14-49-19

@@ -0,0 +1 @@
+{19.3, 42.5, 702}

Code/Python/AM107/AM107-51/2024-11-22_14-47-49

@@ -0,0 +1 @@
+{21.2, 40.5, 440}

Code/Python/AM107/AM107-53/2024-11-22_14-47-16

@@ -0,0 +1 @@
+{18.4, 47, 554}

Code/Python/AM107/AM107-54/2024-11-22_14-45-48

@@ -0,0 +1 @@
+{21.1, 41.5, 651}

Code/Python/AM107/AM107-55/2024-11-22_14-51-49

@@ -0,0 +1 @@
+{22.3, 38, 576}

Code/Python/AM107/AM107-6/2024-11-22_14-47-49

@@ -0,0 +1 @@
+{20.6, 49, 1315}

Code/Python/AM107/AM107-7/2024-11-22_14-50-49

@@ -0,0 +1 @@
+{21.6, 43.5, 669}

Code/Python/AM107/AM107-8/2024-11-22_14-52-08

@@ -0,0 +1 @@
+{18.2, 50, 2229}

Code/Python/AM107/B001/2024-11-22_14-50-49

@@ -0,0 +1 @@
+{21.6, 43.5, 669}

Code/Python/AM107/B002/2024-11-22_14-52-08

@@ -0,0 +1 @@
+{18.2, 50, 2229}

Code/Python/AM107/B103/2024-11-22_14-58-32

@@ -0,0 +1 @@
+{22.1, 37.5, 2199}

Code/Python/AM107/B105/2024-11-22_14-52-48

@@ -0,0 +1 @@
+{20, 47.5, 1678}

Code/Python/AM107/B106/2024-11-22_14-50-11

@@ -0,0 +1 @@
+{19.4, 51.5, 1407}

Code/Python/AM107/B108/2024-11-22_14-46-39

@@ -0,0 +1 @@
+{17.9, 50.5, 876}

Code/Python/AM107/B109/2024-11-22_14-51-50

@@ -0,0 +1 @@
+{20.2, 48, 866}

Code/Python/AM107/B110/2024-11-22_14-49-48

@@ -0,0 +1 @@
+{21.9, 48, 1252}

Code/Python/AM107/B111/2024-11-22_14-53-08

@@ -0,0 +1 @@
+{22.1, 47, 1361}

Code/Python/AM107/B112/2024-11-22_14-45-39

@@ -0,0 +1 @@
+{21.7, 52.5, 2070}

Code/Python/AM107/B113/2024-11-22_14-53-48

@@ -0,0 +1 @@
+{18.3, 56, 1406}

Code/Python/AM107/B201/2024-11-22_14-51-37

@@ -0,0 +1 @@
+{22.5, 47, 1924}

Code/Python/AM107/B202/2024-11-22_14-51-08

@@ -0,0 +1 @@
+{20.2, 50.5, 1395}

Code/Python/AM107/B203/2024-11-22_14-47-49

@@ -0,0 +1 @@
+{20.6, 49, 1315}

Code/Python/AM107/B217/2024-11-22_14-45-39

@@ -0,0 +1 @@
+{20.1, 47, 936}

Code/Python/AM107/B234/2024-11-22_14-53-17

@@ -0,0 +1 @@
+{21.6, 41, 1097}

Code/Python/AM107/C001/2024-11-22_14-51-49

@@ -0,0 +1 @@
+{22.3, 38, 576}

Code/Python/AM107/C002/2024-11-22_14-45-48

@@ -0,0 +1 @@
+{21.1, 41.5, 651}

Code/Python/AM107/C004/2024-11-22_14-51-17

@@ -0,0 +1 @@
+{19.9, 51.5, 1424}

Code/Python/AM107/C006/2024-11-22_14-49-18

@@ -0,0 +1 @@
+{20.1, 48, 877}

Code/Python/AM107/C102/2024-11-22_14-47-16

@@ -0,0 +1 @@
+{18.4, 47, 554}

Code/Python/AM107/E001/2024-11-22_14-56-18

@@ -0,0 +1 @@
+{19.5, 39, 469}

Code/Python/AM107/E003/2024-11-22_14-44-50

@@ -0,0 +1 @@
+{21.6, 39.5, 889}

Code/Python/AM107/E004/2024-11-22_14-50-47

@@ -0,0 +1 @@
+{22.5, 43, 1228}

Code/Python/AM107/E006/2024-11-22_14-53-48

@@ -0,0 +1 @@
+{21.1, 42, 1192}

Code/Python/AM107/E007/2024-11-22_14-47-20

@@ -0,0 +1 @@
+{20.7, 39.5, 924}

Code/Python/AM107/E100/2024-11-22_14-49-16

@@ -0,0 +1 @@
+{23.2, 33.5, 579}

Code/Python/AM107/E101/2024-11-22_14-48-47

@@ -0,0 +1 @@
+{19.1, 39, 518}

Code/Python/AM107/E101/2024-11-22_15-08-49

@@ -0,0 +1 @@
+{19.7, 39, 564}

Code/Python/AM107/E102/2024-11-22_14-49-46

@@ -0,0 +1 @@
+{20.7, 40, 639}

Code/Python/AM107/E106/2024-11-22_14-50-47

@@ -0,0 +1 @@
+{20.7, 42, 1047}

Code/Python/AM107/E207/2024-11-22_14-48-47

@@ -0,0 +1 @@
+{20.3, 38, 547}

Code/Python/AM107/E207/2024-11-22_15-08-50

@@ -0,0 +1 @@
+{20.3, 37.5, 538}

Code/Python/AM107/E208/2024-11-22_14-47-48

@@ -0,0 +1 @@
+{19.8, 43.5, 1016}

Code/Python/AM107/E209/2024-11-22_14-54-12

@@ -0,0 +1 @@
+{21.3, 39.5, 1108}

Code/Python/AM107/E210/2024-11-22_11-18-06

@@ -0,0 +1 @@
+{19.7, 42, 441}

Code/Python/AM107/E210/2024-11-22_14-58-07

@@ -0,0 +1 @@
+{21.2, 36.5, 456}

Code/Python/AM107/Foyer-etudiants-entrée/2024-11-22_14-52-49

@@ -0,0 +1 @@
+{48.9, 45.5, 790}

Code/Python/AM107/Foyer-personnels/2024-11-22_14-51-19

@@ -0,0 +1 @@
+{20.5, 49.5, 1292}

Code/Python/AM107/Local-velo/2024-11-22_14-51-21

@@ -0,0 +1 @@
+{14.9, 49, 443}

Code/Python/AM107/Salle-conseil/2024-11-22_14-52-15

@@ -0,0 +1 @@
+{22.2, 39.5, 514}

Code/Python/AM107/amphi1/2024-11-22_14-47-49

@@ -0,0 +1 @@
+{21.2, 40.5, 440}

Code/Python/AM107/hall-amphi/2024-11-22_14-49-19

@@ -0,0 +1 @@
+{19.3, 42.5, 702}

Code/Python/AM107/hall-entrée-principale/2024-11-22_14-49-49

@@ -0,0 +1 @@
+{19.6, 41, 683}

Code/Python/clientMQTT.py

@@ -5,6 +5,7 @@
 
 from datetime import datetime
 from genericpath import exists
+from pathlib import Path
 
 config = configparser.ConfigParser()
 config.read("config.ini")
@@ -29,7 +30,6 @@ def on_connect(client, userdata, flags, rc):
         print(f"Échec de connexion, code de retour : {rc}")
 
 def on_message(client, userdata, msg):
-    date=datetime.now().strftime("%Y-%m-%d_%H-%M-%S")
     topic = msg.topic
     payload = msg.payload.decode("utf-8")
     parties = topic.split("/")
@@ -40,7 +40,15 @@ def on_message(client, userdata, msg):
     except json.JSONDecodeError:
         data = payload
 
-    if flux_mqtt=="solaredge":
+    if flux_mqtt == "solaredge":
+        if exists(flux_mqtt):
+            repertoire = Path("./solaredge/")
+            liste_fichiers = [f for f in repertoire.iterdir() if f.is_file()]
+            liste_fichiers_tries = sorted(liste_fichiers, key=lambda f: f.stat().st_mtime)
+            dernier_fichier = liste_fichiers_tries[-1] if liste_fichiers_tries else None
+            nom_dernier_fichier = dernier_fichier.name
+            if gestion_periode(nom_dernier_fichier) == False:
+                return        
         if SOLAREDGE_INFO_TYPES[0] == "all" :
             message = f"{data}"
         else:
@@ -57,9 +65,18 @@ def on_message(client, userdata, msg):
         print(message)
         enregistrer_donnees(message,topic)
 
-    if flux_mqtt=="AM107":
+    if flux_mqtt == "AM107":
         salle = parties[2] if len(parties) > 2 else "inconnue"
         if salle in AM107_ROOMS or AM107_ROOMS[0] == "all":
+            if exists(flux_mqtt+"/"+salle):
+                chemin="./"+flux_mqtt+"/"+salle+"/"
+                repertoire = Path(chemin)
+                liste_fichiers = [f for f in repertoire.iterdir() if f.is_file()]
+                liste_fichiers_tries = sorted(liste_fichiers, key=lambda f: f.stat().st_mtime)
+                dernier_fichier = liste_fichiers_tries[-1] if liste_fichiers_tries else None
+                nom_dernier_fichier = dernier_fichier.name
+                if gestion_periode(nom_dernier_fichier) == False:
+                    return            
             if AM107_INFO_TYPES[0] == "all":
                 message = f"{data}"
             else:
@@ -95,6 +112,61 @@ def enregistrer_donnees(data,topic):
         with open(flux_mqtt+"/"+salle+"/"+date, "a") as f:
             f.write(data + "\n")
 
+def gestion_periode(date_sans_seuil):
+    tab_str=date_sans_seuil.split('_')[0].split('-')+date_sans_seuil.split('_')[1].split('-')
+    tab_int=[]
+    for i in range(len(tab_str)):
+        val=int(tab_str[i])
+        tab_int.append(val)
+    tab_int[4]=tab_int[4]+PERIOD
+    while tab_int[4]>60:
+        tab_int[4]=tab_int[4]-60
+        tab_int[3]=tab_int[3]+1
+    while tab_int[3]>24:
+        tab_int[3]=tab_int[3]-24
+        tab_int[2]=tab_int[2]+1
+    mois_pas_ok=True
+    while mois_pas_ok==True:
+        mois_pas_ok=False
+        if tab_int[1]==2:
+            if tab_int[2]>29:
+                mois_pas_ok=True
+                tab_int[2]=tab_int[2]-29
+                tab_int[1]=tab_int[1]+1
+        elif tab_int[1] in [1, 3, 5, 7, 8, 10, 12]:
+            if tab_int[2]>31:
+                mois_pas_ok=True
+                tab_int[2]=tab_int[2]-31
+                tab_int[1]=tab_int[1]+1
+        elif tab_int[1] in [4, 6, 9, 11]:
+            if tab_int[2]>30:
+                mois_pas_ok=True
+                tab_int[2]=tab_int[2]-30
+                tab_int[1]=tab_int[1]+1
+        while tab_int[1]>12:
+            tab_int[1]=tab_int[1]-12
+            tab_int[0]=tab_int[0]+1
+
+    date_avec_seuil=""
+    for i in range(len(tab_int)):
+        elt=tab_int[i]
+        if i in [1,2,4,5]:
+            date_avec_seuil=date_avec_seuil+'-'
+        elif i==3:
+            date_avec_seuil=date_avec_seuil+'_'
+        if elt in [1, 2, 3, 4, 5, 6, 7, 8, 9]:
+            nb='0'+str(elt)
+        else:
+            nb=str(elt)
+        date_avec_seuil=date_avec_seuil+nb
+
+    date_actuelle=datetime.now().strftime("%Y-%m-%d_%H-%M-%S")
+
+    if date_avec_seuil<date_actuelle:
+        return True
+    else:
+        return False
+
 client = mqtt.Client()
 
 client.on_connect = on_connect

Code/Python/solaredge/2024-11-22_11-18-03

@@ -0,0 +1 @@
+{'lastUpdateTime': '2024-11-22 11:04:33', 'lifeTimeData': {'energy': 3320702}, 'lastYearData': {'energy': 2839672}, 'lastMonthData': {'energy': 204800}, 'lastDayData': {'energy': 1093}, 'currentPower': {'power': 746.456}, 'measuredBy': 'INVERTER'}

Code/Python/solaredge/2024-11-22_14-44-29

@@ -0,0 +1 @@
+{'lastUpdateTime': '2024-11-22 14:29:33', 'lifeTimeData': {'energy': 3327160}, 'lastYearData': {'energy': 2846130}, 'lastMonthData': {'energy': 211258}, 'lastDayData': {'energy': 7551}, 'currentPower': {'power': 2719.1514}, 'measuredBy': 'INVERTER'}

Code/Python/solaredge/2024-11-22_15-01-01

@@ -0,0 +1 @@
+{'lastUpdateTime': '2024-11-22 15:00:28', 'lifeTimeData': {'energy': 3328063}, 'lastYearData': {'energy': 2847033}, 'lastMonthData': {'energy': 212161}, 'lastDayData': {'energy': 8454}, 'currentPower': {'power': 2567.5698}, 'measuredBy': 'INVERTER'}