Change Import and UPDATE from AD User

2023-07-27 13:04:05 +02:00
parent 55cc229825
commit 0c65fdea82
10 changed files with 156 additions and 156 deletions
@@ -6,40 +6,40 @@ import mysql_connect


 def adcontroller (ip,name):
-    # command = ["powershell", "-Command",
-    #            "Get-ADUser -Filter * -Properties * | Export-Csv -NoTypeInformation -Encoding UTF8 -Path 'users.csv'"]
-    # subprocess.run(command)
-    #
-    # # CSV-Datei einlesen und Feldnamen auslesen
-    # with open("users.csv", "r", encoding='utf-8-sig') as file:
-    #     reader = csv.DictReader(file)
-    #     fieldnames = reader.fieldnames
-    #
-    # # Tabelle erstellen, falls sie noch nicht existiert
-    # table_name = "Active-Directory-User"
-    # create_table_query = f"CREATE TABLE IF NOT EXISTS `{table_name}` (id INT AUTO_INCREMENT PRIMARY KEY, importdate BIGINT(11), "
-    # for field in fieldnames:
-    #     create_table_query += f"`{field}` TEXT, "
-    # create_table_query = create_table_query.rstrip(", ") + ")"
-    # mysql_connect.create_database(create_table_query,name)
-    #
-    # # Daten aus der CSV-Datei in die Tabelle einfügen
-    # with open("users.csv", "r", encoding='utf-8-sig') as file:
-    #     reader = csv.reader(file)
-    #     next(reader)  # Überspringe die erste Zeile (Feldnamen)
-    #     for row in reader:
-    #         row = [cell if cell.strip() else "-" for cell in row]
-    #         unix_time = int(datetime.now().timestamp())
-    #         print(unix_time)
-    #         row = [unix_time] + row
-    #         insert_query = f"INSERT INTO `{table_name}` (importdate, `{'`, `'.join(fieldnames)}`) VALUES (%s, {', '.join(['%s'] * len(fieldnames))})"
-    #         mysql_connect.add_user(insert_query, name, row)
-    #
-    # # Datenbankverbindung schließen
-    #
-    # command = ["powershell", "-Command",
-    #            "Get-ADGroupMember -Identity G-RDP-User | Export-Csv -NoTypeInformation -Encoding UTF8 -Path 'group.csv'"]
-    # subprocess.run(command)
+    command = ["powershell", "-Command",
+               "Get-ADUser -Filter * -Properties * | Export-Csv -NoTypeInformation -Encoding UTF8 -Path 'users.csv'"]
+    subprocess.run(command)
+
+    # CSV-Datei einlesen und Feldnamen auslesen
+    with open("users.csv", "r", encoding='utf-8-sig') as file:
+        reader = csv.DictReader(file)
+        fieldnames = reader.fieldnames
+
+    # Tabelle erstellen, falls sie noch nicht existiert
+    table_name = "Active-Directory-User"
+    create_table_query = f"CREATE TABLE IF NOT EXISTS `{table_name}` (id INT AUTO_INCREMENT PRIMARY KEY, importdate BIGINT(11), "
+    for field in fieldnames:
+        create_table_query += f"`{field}` TEXT, "
+    create_table_query = create_table_query.rstrip(", ") + ")"
+    mysql_connect.create_database(create_table_query,name)
+
+    # Daten aus der CSV-Datei in die Tabelle einfügen
+    with open("users.csv", "r", encoding='utf-8-sig') as file:
+        reader = csv.reader(file)
+        next(reader)  # Überspringe die erste Zeile (Feldnamen)
+        for row in reader:
+            row = [cell if cell.strip() else "-" for cell in row]
+            unix_time = int(datetime.now().timestamp())
+            print(unix_time)
+            row = [unix_time] + row
+            insert_query = f"INSERT INTO `{table_name}` (importdate, `{'`, `'.join(fieldnames)}`) VALUES (%s, {', '.join(['%s'] * len(fieldnames))})"
+            mysql_connect.add_user(insert_query, name, row)
+
+    # Datenbankverbindung schließen
+
+    command = ["powershell", "-Command",
+               "Get-ADGroupMember -Identity G-RDP-User | Export-Csv -NoTypeInformation -Encoding UTF8 -Path 'group.csv'"]
+    subprocess.run(command)

    # CSV-Datei einlesen und Feldnamen auslesen
    with open("group.csv", "r", encoding='utf-8-sig') as file: