add tickets controller

.env

@@ -0,0 +1,7 @@
+## Ticketsystem
+ZAMMAD_URL = "https://ticket.stines.de/api/v1"
+ZAMMAD_API_TOKEN ="1v4XGY7cZpBXSfb4s_tIBbywQjcaDV6q65IXQyVXrrBDqVtmAtLxM5tOqIAp0VXZ"
+
+## API-Server
+API_SERVER = "http://api.stines.de:8001"
+API_TOKEN = "^YWUbG7yX*V!tV^KBSd*2c&vdN3wV9a2i7f3hfGFMBYFxi6#mMiJGiaA5KEHE%B*miK%qb7rQ67gmcYP@gqmux8"

.idea/vcs.xml

@@ -2,6 +2,5 @@
 <project version="4">
   <component name="VcsDirectoryMappings">
     <mapping directory="" vcs="Git" />
-    <mapping directory="$PROJECT_DIR$/1.1" vcs="Git" />
   </component>
 </project>

controller/tickets.py

@@ -0,0 +1,98 @@
+import requests
+import json
+from datetime import datetime, timedelta
+from dotenv import load_dotenv
+import os
+
+# Lade die Umgebungsvariablen aus der .env Datei
+load_dotenv()
+
+# Hole die Werte aus der .env Datei
+zammad_url = os.getenv('ZAMMAD_URL')
+zammad_api_token = os.getenv('ZAMMAD_API_TOKEN')
+
+api_url = os.getenv('API_SERVER')
+api_token = os.getenv('API_TOKEN')
+
+headers_zammad = {"Authorization": f"Token token={zammad_api_token}"}
+headers_api = {"access_token": f"{api_token}", "Content-Type": "application/json"}
+
+# API Anfrage an Zammad für Organisationen
+response_org = requests.get(f"{zammad_url}/organizations", headers=headers_zammad)
+# API Anfrage an Zammad für Benutzer
+response_user = requests.get(f"{zammad_url}/users", headers=headers_zammad)
+
+if response_org.status_code == 200 and response_user.status_code == 200:
+    organizations = response_org.json()
+    users = response_user.json()
+
+    # Erstelle ein Dictionary, das die Organisationen nach ID speichert
+    org_dict = {org['id']: org['domain'] for org in organizations}
+    # Erstelle ein Dictionary, das die Benutzer nach ID speichert
+    user_dict = {user['id']: user for user in users}
+
+    # Berechne den ersten und letzten Tag des letzten Monats
+    today = datetime.now()
+    first_day_last_month = today.replace(day=1) - timedelta(days=1)
+    first_day_last_month = first_day_last_month.replace(day=1)
+    last_day_last_month = today.replace(day=1) - timedelta(days=1)
+
+    # Formatierung der Daten für den Vergleich
+    start_date_str = first_day_last_month.strftime('%Y-%m-%dT%H:%M:%SZ')
+    end_date_str = last_day_last_month.strftime('%Y-%m-%dT%H:%M:%SZ')
+
+    # API Anfrage an Zammad für Tickets mit Pagination und Sortierung
+    params = {
+        'query': f"last_close_at:[{start_date_str} TO {end_date_str}]",
+        'sort_by': 'last_close_at',
+        'order': 'desc',
+        'per_page': 100,
+        'page': 1
+    }
+    response_tickets = requests.get(f"{zammad_url}/tickets/search", headers=headers_zammad, params=params)
+
+    if response_tickets.status_code == 200:
+        response_data = response_tickets.json()
+
+        # Extrahiere die Ticket-IDs und die zugehörigen Ticket-Daten aus assets
+        ticket_ids = response_data.get('tickets', [])
+        ticket_assets = response_data.get('assets', {}).get('Ticket', {})
+
+        # Filtere die Tickets, extrahiere die benötigten Felder und verknüpfe mit Organisationen und Benutzern
+        filtered_tickets = [
+            {
+                'number': ticket_data.get('number'),
+                'title': ticket_data.get('title'),
+                'create_date': datetime.strptime(ticket_data.get('created_at'), '%Y-%m-%dT%H:%M:%S.%fZ').strftime('%Y-%m-%d %H:%M:%S') if ticket_data.get('created_at') else None,
+                'closed_date': datetime.strptime(ticket_data.get('last_close_at'), '%Y-%m-%dT%H:%M:%S.%fZ').strftime('%Y-%m-%d %H:%M:%S') if ticket_data.get('last_close_at') else None,
+                'organization_domain': org_dict.get(ticket_data.get('organization_id')),
+                'time_unit': ticket_data.get('time_unit') if ticket_data.get('time_unit') is not None else "0",
+                'created_by': user_dict.get(ticket_data.get('created_by_id'), {}).get('login')
+            }
+            for ticket_id in ticket_ids
+            if (ticket_data := ticket_assets.get(str(ticket_id)))
+        ]
+
+        # Ausgabe der gefilterten Tickets als JSON-String
+        json_output = json.dumps(filtered_tickets, indent=4, ensure_ascii=False)
+
+
+        for tickets in filtered_tickets:
+        # POST-Anfrage an den anderen API-Server
+            print(tickets)
+            response_post = requests.post(f"{api_url}/post/tickets", headers=headers_api, json=tickets)
+
+        # Überprüfen der Antwort des API-Servers
+            if response_post.status_code == 200 or response_post.status_code == 201:
+                print("Data successfully posted.")
+            else:
+                print(f"Failed to post data. Status code: {response_post.status_code}")
+                print(f"Response content: {response_post.content.decode('utf-8')}")
+
+    else:
+        print(f"Failed to retrieve tickets. Status code: {response_tickets.status_code}")
+else:
+    if response_org.status_code != 200:
+        print(f"Failed to retrieve organizations. Status code: {response_org.status_code}")
+    if response_user.status_code != 200:
+        print(f"Failed to retrieve users. Status code: {response_user.status_code}")