Update app.py

app.py

@@ -782,19 +782,20 @@ def send_request():
 
 DATABASE_NAME = 'data_gc.db'
 
-
-
 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')
     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}")
 
+    # Преобразование данных пользователя на основе шаблона сопоставления
     transformed_data = {}
     for json_key, db_column in mapping_template.items():
         value = user_data.get(json_key, "")
@@ -804,18 +805,19 @@ 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",
         "shop_st", "curator", "pr1", "pr2", "pr3", "pr4", "pr5", "ad_url",
         "key_pr", "n_con", "canal", "data_t"
     ]
-
     for field in required_fields:
         if field not in transformed_data:
             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('+'):
@@ -823,12 +825,15 @@ 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 в отдельный блок
     web_st_value = 0
     if user:
-        web_st_value = int(user[0]) if user[0] else 0
+        # Проверка текущего значения web_st и его инкрементация
+        web_st_value = 1 if user[0] is None or user[0] == "" or user[0] == 0 else int(user[0])
         web_st_value += 1
     logging.debug(f"Calculated web_st_value: {web_st_value}")
 
+    # Обновление данных пользователя в базе данных
     update_query = "UPDATE contacts SET "
     update_values = []
     for column, value in transformed_data.items():
@@ -839,6 +844,7 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     logging.debug(f"Update query: {update_query} with values: {update_values}")
     cursor.execute(update_query, update_values)
 
+    # Если пользователь не найден, вставка нового пользователя
     if cursor.rowcount == 0:
         columns = ', '.join(transformed_data.keys()) + ", web_st"
         placeholders = ', '.join('?' for _ in transformed_data) + ", ?"
@@ -847,10 +853,48 @@ 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_get_request', methods=['GET'])
+def send_get_request():
+    token = request.args.get('token')
+    webinarId = request.args.get('webinarId')
+    url = f'https://online.bizon365.ru/api/v1/webinars/reports/get?webinarId={webinarId}'
+
+    response = requests.get(url, headers={'X-Token': token})
+
+    if response.status_code == 200:
+        data = response.json()
+
+        report = data.get('report', {})
+        messages = data.get('messages', {})
+
+        report_json_str = report.get('report', '{}')
+        try:
+            report_json = json.loads(report_json_str)
+        except json.JSONDecodeError:
+            report_json = {}
+
+        messages_json_str = report.get('messages', '{}')
+        try:
+            messages_json = json.loads(messages_json_str)
+        except json.JSONDecodeError:
+            messages_json = {}
+
+        users_meta = report_json.get('usersMeta', {})
+
+        # Обновление или добавление каждого пользователя в базу данных data_gc.db
+        for user_id, user_data in users_meta.items():
+            user_data['messages'] = messages_json
+            update_or_insert_user(DATABASE_NAME, user_data, mapping_template)
+
+        return jsonify({'status': 'User data saved successfully'})
+    else:
+        return jsonify({'error': 'Failed to fetch data from the API'}), response.status_code
+