Update to prod test

app.py

@@ -15,17 +15,19 @@ blob_service_client = BlobServiceClient.from_connection_string(connection_string
 def upload_blob(pdf_name, json_data, pdf_data_jobdescription,pdf_data_cvs):
     try:
         container_name = "jobdescriptions"
-        json_blob_name = f"{pdf_name}_jsondata.json"
+        # json_blob_name = f"{pdf_name}_jsondata.json"
         pdf_blob_name_jobdescription = f"{pdf_name}.pdf"
 
         container_client = blob_service_client.get_container_client(container_name)
 
-        json_blob_client = container_client.get_blob_client(json_blob_name)
-        json_blob_client.upload_blob(json_data.encode('utf-8'), overwrite=True)
+        # json_blob_client = container_client.get_blob_client(json_blob_name)
+        # json_blob_client.upload_blob(json_data.encode('utf-8'), overwrite=True)
 
         pdf_blob_client = container_client.get_blob_client(pdf_blob_name_jobdescription)
         pdf_blob_client.upload_blob(pdf_data_jobdescription, overwrite=True)
 
+        upload_job_db_item(pdf_name,len(pdf_data_cvs),json.loads(json_data))
+
         links = []
         names = []
         for i,cv in enumerate(pdf_data_cvs):
@@ -51,6 +53,32 @@ def upload_blob(pdf_name, json_data, pdf_data_jobdescription,pdf_data_cvs):
         print(f"Fehler beim Hochladen der Daten: {str(e)}")
         return False
 
+def upload_job_db_item(id, number_of_applicants, data):
+    endpoint = "https://wg-candidate-data.documents.azure.com:443/"
+    key = os.getenv("CONNECTION_DB")
+    client = CosmosClient(endpoint, key)
+    database = client.get_database_client("ToDoList")
+    container = database.get_container_client("JobData")
+    job_item = {
+        "id": id,
+        'partitionKey' : 'wg-job-data-v1',
+        "title": data["title"],
+        "number_of_applicants": number_of_applicants,
+        "every_interview_conducted": False,
+        "evaluation_email": data["email"],
+        "question_one": data["question_one"],
+        "question_two": data["question_two"],
+        "question_three": data["question_three"],
+    }
+    try:
+        # Fügen Sie das Element in den Container ein
+        container.create_item(body=job_item)
+        print("Eintrag erfolgreich in die Cosmos DB eingefügt. Container: Job Data")
+    except exceptions.CosmosHttpResponseError as e:
+        print(f"Fehler beim Schreiben in die Cosmos DB: {str(e)}")
+    except Exception as e:
+        print(f"Allgemeiner Fehler: {str(e)}")
+
 def upload_db_item(name, data, job_description_id, cv_id):
 
     endpoint = "https://wg-candidate-data.documents.azure.com:443/"
@@ -75,7 +103,7 @@ def upload_db_item(name, data, job_description_id, cv_id):
     try:
         # Fügen Sie das Element in den Container ein
         container.create_item(body=candidate_item)
-        print("Eintrag erfolgreich in die Cosmos DB eingefügt.")
+        print("Eintrag erfolgreich in die Cosmos DB eingefügt. Container: Items(candidate Data)")
     except exceptions.CosmosHttpResponseError as e:
         print(f"Fehler beim Schreiben in die Cosmos DB: {str(e)}")
     except Exception as e: