150 lines
4.5 KiB
Python
150 lines
4.5 KiB
Python
import Controller.ssh_tunnel as ssh_tunnel
|
|
ssh_tunnel.server_start()
|
|
import socket
|
|
from Controller import adcontroller_export, exchange_export, rds_export, smtp_export, zammad, system_info
|
|
import Controller.mysql_connect as mysql_connect
|
|
import random
|
|
import subprocess
|
|
import socket
|
|
import os
|
|
|
|
## Gibt Name der Datei zum Debugen aus
|
|
filename = os.path.basename(__file__)
|
|
|
|
def get_local_ip():
|
|
try:
|
|
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
|
|
s.connect(("8.8.8.8", 80))
|
|
local_ip = s.getsockname()[0]
|
|
s.close()
|
|
print(local_ip)
|
|
return local_ip
|
|
except Exception as e:
|
|
print(f"Fehler beim Abrufen der lokalen IP-Adresse: {e}")
|
|
return None
|
|
|
|
def adcontroller(ip,name):
|
|
adcontroller_export.adcontroller(ip, name)
|
|
|
|
def exchange(ip,name):
|
|
exchange_export.exchange(ip, name)
|
|
|
|
def smtp(ip,name,token):
|
|
smtp_export.smtp(ip, name, token)
|
|
|
|
def rds(ip, name):
|
|
rds_export.rds(ip, name)
|
|
|
|
def cms(ip, servername):
|
|
## Import User als RAW
|
|
print("" + ip + servername)
|
|
|
|
def mstore(ip, servername):
|
|
## Import User(last Check) als RAW
|
|
print("" + ip + servername)
|
|
|
|
def cloud(ip,servername):
|
|
## Import User(space) als RAW
|
|
print("" + ip + servername)
|
|
|
|
def vpn(ip,servername):
|
|
## Import Online Time als RAW
|
|
print("" + ip + servername)
|
|
|
|
def nginx(ip,servername):
|
|
## Import Letsencrypt Time als RAW
|
|
print("" + ip + servername)
|
|
|
|
def tickets(ip,name):
|
|
zammad.tickets(ip,name)
|
|
|
|
def data(ip,servername):
|
|
## Import Space Used als RAW
|
|
print("" + ip + servername)
|
|
|
|
def omada(ip,servername):
|
|
## Import Access als RAW
|
|
print("" + ip + servername)
|
|
|
|
def matomo(ip,servername):
|
|
## Import Statics als RAW
|
|
print("" + ip + servername)
|
|
|
|
def gucamole(ip,servername):
|
|
## Import User + Maschinen als RAW
|
|
print("" + ip + servername)
|
|
|
|
def create_windows_task(task_name, command, schedule):
|
|
try:
|
|
command_line = f'schtasks /F /create /ru "SYSTEM" /tn "{task_name}" /tr "{command}" /sc {schedule}'
|
|
subprocess.run(command_line, shell=True, check=True)
|
|
print(f"{filename}-Windows task '{task_name}' created successfully.")
|
|
except subprocess.CalledProcessError as e:
|
|
print(f"{filename}-Failed to create Windows task. Error: {e}")
|
|
|
|
|
|
|
|
# query = "SELECT * FROM `Stines-GmbH`.`Kunden-Server` WHERE `IP-Adresse` = ""'{}'""".format(get_local_ip())
|
|
|
|
query = "SELECT * FROM `Stines-GmbH`.`Kunden-Server` WHERE `IP-Adresse` = ""'{}'""".format("172.19.1.5")
|
|
|
|
print(f"{filename}-Before Get List")
|
|
list = mysql_connect.get_ip(query)
|
|
print(f"{filename}-Atfer Get IP")
|
|
|
|
if list == []:
|
|
query_insert = f"INSERT INTO `Kunden-Server` (Name,`Server-Name`,`IP-Adresse`,Funktion,CPU,RAM,Speicher) VALUES ('unkown','{socket.gethostname()}','{get_local_ip()}','-','{system_info.get_cpu_info()}','{system_info.get_ram_info()}','{system_info.get_hdd_info()}')"
|
|
print(f"{filename}-List is Empty")
|
|
mysql_connect.add_user(query_insert,"Stines-GmbH","")
|
|
|
|
set_ipaddress = []
|
|
print(f"{filename}-Before Row")
|
|
# Ergebnisse durchlaufen und ausgeben
|
|
for row in list:
|
|
name = row[2]
|
|
ipadress = row[4]
|
|
set_ipaddress = row[4]
|
|
lastchange = row[6]
|
|
funktion = row[7]
|
|
token = row[8]
|
|
print(f"{filename}-Inside Row {name}-{funktion}")
|
|
|
|
cursor = mysql_connect.get_database()
|
|
|
|
# Überprüfen, ob die Datenbank bereits existiert
|
|
|
|
database_exists = False
|
|
for (db_name,) in cursor:
|
|
if name in str(db_name):
|
|
database_exists = True
|
|
if "-" in str(db_name):
|
|
database_exists = True
|
|
|
|
# Datenbank erstellen, wenn sie noch nicht existiert
|
|
print(f"{filename}-{database_exists}")
|
|
if not database_exists:
|
|
create_database_query = f"CREATE DATABASE `{name}`"
|
|
mysql_connect.create_database(create_database_query,name)
|
|
print(f"{filename}-Die Datenbank '`{name}`' wurde erfolgreich erstellt.")
|
|
else:
|
|
print(f"{filename}-Die Datenbank '`{name}`' existiert bereits.")
|
|
|
|
if token is not None:
|
|
eval(funktion + '("' + ipadress + '","' + name + '","' + token + '")')
|
|
else:
|
|
if funktion == "-":
|
|
break
|
|
else:
|
|
eval(funktion + '("' + ipadress + '","' + name + '")')
|
|
|
|
# print(f"{filename}-FOR system_info_get: {set_ipaddress}")
|
|
system_info.set_system_info(f"{set_ipaddress}")
|
|
|
|
print(f"{filename}-FOR schedule: {ipadress}")
|
|
task_name = "Reports"
|
|
command_to_execute = "C:\\Scripte\\Start.exe"
|
|
schedule = f"daily /st 23:{random.randint(0, 59)}" # You can customize the schedule here
|
|
|
|
create_windows_task(task_name, command_to_execute, schedule)
|
|
|
|
ssh_tunnel.server_stop() |