Update app.py

app.py

@@ -786,14 +786,23 @@ DATABASE_NAME = 'data_gc.db'
 
 
 
+verifikation_start = "1"  # Глобальная переменная для управления верификацией
+curator_on_off = "1"  # Глобальная переменная для управления назначением куратора
 
+current_curator_index = 0
 
+def verify_phone_number(phone_number):
+    if verifikation_start == "1":
+        # Здесь должен быть ваш код для верификации номера телефона
+        # Например, вызов внешнего API для проверки наличия WhatsApp
+        return "true"  # Заглушка для примера
+    else:
+        return "false"
 
 def update_or_insert_user(db_name, user_data, mapping_template):
     conn = sqlite3.connect(db_name)
     cursor = conn.cursor()
 
-    # Получение email пользователя из данных
     email = user_data.get('email')
     if not email:
         logging.error(f"User data missing email: {user_data}")
@@ -801,20 +810,16 @@ def update_or_insert_user(db_name, user_data, mapping_template):
 
     logging.debug(f"Processing user with email: {email}")
     
-    # Проверка существования пользователя в базе данных по email
     cursor.execute("SELECT web_st FROM contacts WHERE email = ?", (email,))
     user = cursor.fetchone()
     logging.debug(f"User found: {user}")
 
-    # Вынесение увеличения значения web_st в отдельный блок
-    web_st_value = 1  # Инициализация значения web_st
+    web_st_value = 1
     if user:
-        # Проверка текущего значения web_st и его инкрементация
         current_web_st = user[0] if user[0] is not None and user[0] != "" else 0
         web_st_value = int(current_web_st) + 1
         logging.debug(f"Calculated web_st_value: {web_st_value}")
 
-        # Обновление значения web_st
         cursor.execute("UPDATE contacts SET web_st = ? WHERE email = ?", (web_st_value, email))
         conn.commit()
         conn.close()
@@ -823,19 +828,16 @@ def update_or_insert_user(db_name, user_data, mapping_template):
         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, "")
         
         if isinstance(value, list):
-            # Проверяем тип элементов списка
             if all(isinstance(item, str) for item in value):
-                transformed_data[db_column] = "; ".join(value)  # Сохраняем сообщения в строку
+                transformed_data[db_column] = "; ".join(value)
             else:
                 logging.error(f"Expected list of strings for key {json_key}, but got: {value}")
                 transformed_data[db_column] = ""
@@ -843,7 +845,6 @@ def update_or_insert_user(db_name, user_data, mapping_template):
             transformed_data[db_column] = str(value)
     logging.debug(f"Transformed data: {transformed_data}")
 
-    # Заполнение обязательных полей значениями по умолчанию
     required_fields = [
         "vk_id", "chat_id", "ws_st", "ws_stop", "web_st", "fin_prog",
         "b_city", "b_fin", "b_ban", "b_ign", "b_baners", "b_butt", "b_mess",
@@ -855,7 +856,6 @@ def update_or_insert_user(db_name, user_data, mapping_template):
             transformed_data[field] = ""
     logging.debug(f"Transformed data after adding required fields: {transformed_data}")
 
-    # Обработка номера телефона, если он есть
     if 'phone' in user_data:
         phone = user_data['phone']
         if phone.startswith('+'):
@@ -863,10 +863,8 @@ def update_or_insert_user(db_name, user_data, mapping_template):
         transformed_data['phone'] = phone
     logging.debug(f"Transformed data after phone processing: {transformed_data}")
 
-    # Добавление значения web_st в данные для вставки
     transformed_data['web_st'] = web_st_value
 
-    # Обновление данных пользователя в базе данных
     if user:
         update_query = "UPDATE contacts SET "
         update_values = []
@@ -885,12 +883,10 @@ def update_or_insert_user(db_name, user_data, mapping_template):
         logging.debug(f"Insert query: {insert_query} with values: {insert_values}")
         cursor.execute(insert_query, insert_values)
 
-    # Подтверждение изменений и закрытие соединения
     conn.commit()
     conn.close()
     logging.debug(f"User with email {email} processed successfully")
 
-
 @app.route('/send_request', methods=['POST'])
 def send_request():
     token = request.form.get('token')
@@ -907,9 +903,6 @@ def send_request():
     else:
         return jsonify({'error': 'Failed to fetch data from the API'}), response.status_code
 
-
-
-
 @app.route('/send_get_request', methods=['GET'])
 def send_get_request():
     token = request.args.get('token')
@@ -918,17 +911,15 @@ def send_get_request():
 
     try:
         response = requests.get(url, headers={'X-Token': token})
-        response.raise_for_status()  # Проверка на ошибки HTTP
+        response.raise_for_status()
         data = response.json()
 
-        # Убедитесь, что report существует в данных
         if data is None or 'report' not in data:
             return jsonify({'error': 'No report data found'}), 500
 
         report = data.get('report', {})
         messages = data.get('messages', {})
 
-        # Проверка на None перед использованием
         if report is None:
             return jsonify({'error': 'No report data found in the response'}), 500
 
@@ -960,9 +951,6 @@ def send_get_request():
     except requests.exceptions.RequestException as e:
         return jsonify({'error': f'API request failed: {str(e)}'}), 500
 
-
-
-
 @app.route('/webhookbz', methods=['POST'])
 def webhookbz():
     api_sys_control = request.args.get('api_sys')