Change Create Windows Task to main.py

Controller/mysql_connect.py

@@ -30,26 +30,29 @@ def database(query,name,user):
     )
     mydb.connect()
     cursor = mydb.cursor()
-    if user:
-        if "SELECT" in query:
-            cursor.execute(query,user)
+    if "SELECT" in query:
+        if user:
+            cursor.execute(query, user)
             return cursor.fetchone()
         else:
-            cursor.execute(query,user)
-            mydb.commit()
-    else:
-        cursor.execute(query)
-    if "SELECT" in query:
-        return cursor.fetchall()
+            cursor.execute(query, user)
+            return cursor.fetchall()
     if "SHOW" in query:
+        cursor.execute(query )
         return cursor.fetchall()
+    if "INSERT" in query:
+        cursor.execute(query)
+        mydb.commit()
+    if "UPDATE" in query:
+        cursor.execute(query)
+        mydb.commit()
     mydb.close()
     server.stop()
 def get_ip(query):
     print("GetIP")
     user = ""
     name = ""
-    return database(query, name,user)
+    return database(query, name, user)
 def get_database():
     name = ""
     user = ""
@@ -64,7 +67,11 @@ def create_database(query,name):
     except Exception as e:
         print("Ein Fehler ist aufgetreten:", str(e))
 def add_user(query,name,user):
-        return database(query,name,user)
+    try:
+        database(query, name, user)
+        return ("User Added")
+    except Exception as e:
+        print("Ein Fehler ist aufgetreten:", str(e))
 
 def get_user(query,name,user):
     return database(query,name,user)

Controller/smtp_export.py

@@ -1,6 +1,6 @@
 import requests
 from datetime import datetime
-import Controller.mysql_connect
+from Controller import mysql_connect
 
 
 def smtp(ip,name,mailcow_token):

Controller/system_info.py

@@ -4,6 +4,9 @@ import math
 import cpuinfo
 from Controller import mysql_connect
 
+def get_cpu_info():
+    return cpuinfo.get_cpu_info()['brand_raw']
+
 def get_cpu_sql():
     query = f"SELECT `Prozessor-Anzahl` FROM `CPU-Liste` WHERE `CPU-Name`='{cpuinfo.get_cpu_info()['brand_raw']}'"
     return mysql_connect.get_cpu(query,"Stines-GmbH",cpuinfo.get_cpu_info()['brand_raw'])
@@ -25,5 +28,5 @@ def get_hdd_info():
 
 # Informationen über die CPU
 def set_system_info(name,ipadress):
-    query = f"UPDATE `Kunden-Server` SET RAM={get_ram_info()}, Prozessor={get_cpu_sql()[0]}, CPU='{cpuinfo.get_cpu_info()['brand_raw']}' WHERE `IP-Adresse`='{ipadress}'"
+    query = f"UPDATE `Kunden-Server` SET RAM={get_ram_info()}, Prozessor={get_cpu_sql()[0]}, CPU='{get_cpu_info()}' WHERE `IP-Adresse`='{ipadress}'"
     return mysql_connect.update_cpu(query,"Stines-GmbH",get_cpu_sql()[0])