Update app.py

app.py

@@ -786,51 +786,35 @@ 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}")
         return
 
-    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()
-        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, "")
         if isinstance(value, list):
-            transformed_data[db_column] = "1" if value else "0"
+            transformed_data[db_column] = json.dumps(value) if value else ""
         else:
             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",
@@ -840,20 +824,33 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     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('+'):
             phone = phone[1:]
         transformed_data['phone'] = phone
-    logging.debug(f"Transformed data after phone processing: {transformed_data}")
 
-    # Добавление значения web_st в данные для вставки
     transformed_data['web_st'] = web_st_value
 
-    # Обновление данных пользователя в базе данных
+    # Проверка наличия массива сообщений и установка значения
+    if 'messages' in user_data and isinstance(user_data['messages'], list):
+        transformed_data['b_mess'] = json.dumps(user_data['messages'])
+    else:
+        transformed_data['b_mess'] = ""
+
+    # Проверка наличия массива баннеров и установка значения
+    if 'banners' in user_data and isinstance(user_data['banners'], list):
+        transformed_data['b_baners'] = '1'
+    else:
+        transformed_data['b_baners'] = '0'
+
+    # Проверка наличия массива кнопок и установка значения
+    if 'buttons' in user_data and isinstance(user_data['buttons'], list):
+        transformed_data['b_butt'] = '1'
+    else:
+        transformed_data['b_butt'] = '0'
+
     if user:
         update_query = "UPDATE contacts SET "
         update_values = []
@@ -862,20 +859,18 @@ def update_or_insert_user(db_name, user_data, mapping_template):
             update_values.append(value)
         update_query = update_query.rstrip(", ") + " WHERE email = ?"
         update_values.append(email)
-        logging.debug(f"Update query: {update_query} with values: {update_values}")
         cursor.execute(update_query, update_values)
     else:
         columns = ', '.join(transformed_data.keys())
         placeholders = ', '.join('?' for _ in transformed_data)
         insert_query = f"INSERT INTO contacts ({columns}) VALUES ({placeholders})"
         insert_values = list(transformed_data.values())
-        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():
@@ -905,10 +900,9 @@ def send_get_request():
 
         users_meta = report_json.get('usersMeta', {})
 
-        # Обновление или добавление каждого пользователя в базу данных data_gc.db
         processed_emails = set()
         for user_id, user_data in users_meta.items():
-            user_data['messages'] = messages_json
+            user_data['messages'] = messages.get(user_id, [])
             email = user_data.get('email')
             if email not in processed_emails:
                 update_or_insert_user(DATABASE_NAME, user_data, mapping_template)
@@ -936,7 +930,6 @@ def send_get_request():
 
 
 
-
 
 @app.route('/biz_v', methods=['GET'])
 def biz_v():