Update app.py

app.py

@@ -810,14 +810,16 @@ def verify_phone_number_biz(phone_number):
     full_url_ver = f"{wa_url}{wa_ak}{ws_url_ver}{wa_api_key}"
     payload = {"phoneNumber": phone_number}
     headers = {'Content-Type': 'application/json'}
-    response = requests.post(full_url_ver, headers=headers, json=payload)
-    if response.status_code == 200:
+    try:
+        response = requests.post(full_url_ver, headers=headers, json=payload)
+        response.raise_for_status()
         response_body = response.json()
+        logging.debug(f"Phone verification response: {response_body}")
         return response_body.get('existsWhatsapp', 'false')
-    else:
+    except requests.RequestException as e:
+        logging.error(f"Error during phone verification: {str(e)}")
         return "Error"
 
-
 def update_or_insert_user_biz(db_name, user_data, mapping_template):
     conn = sqlite3.connect(db_name)
     cursor = conn.cursor()
@@ -841,15 +843,10 @@ def update_or_insert_user_biz(db_name, user_data, mapping_template):
 
         cursor.execute("UPDATE contacts SET web_st = ? WHERE email = ?", (web_st_value, email))
         conn.commit()
-        conn.close()
         logging.debug(f"User {email} web_st updated to {web_st_value}")
     else:
-        conn.close()
         logging.debug(f"User {email} not found, proceeding with insert")
 
-    conn = sqlite3.connect(db_name)
-    cursor = conn.cursor()
-
     transformed_data = {}
     for json_key, db_column in mapping_template.items():
         value = user_data.get(json_key, "")
@@ -887,18 +884,19 @@ def update_or_insert_user_biz(db_name, user_data, mapping_template):
     # Верификация номера телефона
     if 'phone' in user_data and verifikation_start == "1":
         phone_verification_result = verify_phone_number_biz(transformed_data['phone'])
-        logging.debug(f"Phone verification result for {email}: {phone_verification_result}")  # Логирование результата верификации
+        logging.debug(f"Phone verification result for {email}: {phone_verification_result}")
         if phone_verification_result == "true":
             transformed_data['ws_st'] = "True"
         else:
             transformed_data['ws_st'] = "False"
+    logging.debug(f"Transformed data after phone verification: {transformed_data}")
 
     # Назначение куратора
     if curator_on_off == "1":
         global current_curator_index
         transformed_data['curator'] = curators[current_curator_index]
         current_curator_index = (current_curator_index + 1) % len(curators)
-        logging.debug(f"Curator assigned for {email}: {transformed_data['curator']}")  # Логирование назначенного куратора
+        logging.debug(f"Curator assigned for {email}: {transformed_data['curator']}")
 
     if user:
         update_query = "UPDATE contacts SET "
@@ -1016,8 +1014,7 @@ def webhookbz_biz():
 
         return jsonify({'status': 'User data saved successfully'})
     else:
-        return jsonify({'error': 'Failed to fetch data from the API'}), response.status_code
-
+        return jsonify({'error': 'Failed to fetch data from the API'}), 500