Update app.py

app.py

@@ -772,10 +772,11 @@ def send_request():
 DATABASE_NAME = 'data_gc.db'
 
 def update_or_insert_user(db_name, user_data, mapping_template):
-    conn = sqlite3.connect(db_name)
+    conn = sqlite3.connect(db_name, timeout=10, check_same_thread=False)
     cursor = conn.cursor()
 
     email = user_data.get('email')
+    vk_id = user_data.get('vk_id', 'default_vk_id')  # Используйте значение по умолчанию для vk_id
     
     cursor.execute("SELECT web_st FROM contacts WHERE email = ?", (email,))
     user = cursor.fetchone()
@@ -794,8 +795,8 @@ def update_or_insert_user(db_name, user_data, mapping_template):
         update_values.extend([web_st_value, email])
         cursor.execute(update_query, update_values)
     else:
-        columns = ', '.join(mapping_template.values()) + ", web_st"
-        placeholders = ', '.join('?' for _ in mapping_template) + ", ?"
+        columns = ', '.join(mapping_template.values()) + ", web_st, vk_id"
+        placeholders = ', '.join('?' for _ in mapping_template) + ", ?, ?"
         insert_query = f"INSERT INTO contacts ({columns}) VALUES ({placeholders})"
         insert_values = []
         for json_key, db_column in mapping_template.items():
@@ -803,7 +804,7 @@ def update_or_insert_user(db_name, user_data, mapping_template):
             if isinstance(value, list):
                 value = "-1" if value else "0"
             insert_values.append(str(value))
-        insert_values.append(0)
+        insert_values.extend([0, vk_id])
         cursor.execute(insert_query, insert_values)
 
     conn.commit()
@@ -837,7 +838,6 @@ def send_get_request():
 
         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)
@@ -865,7 +865,6 @@ def send_get_request():
 
 
 
-
 
 
 @app.route('/biz_v', methods=['GET'])