Update app.py

app.py

@@ -71,6 +71,13 @@ def init_db(db_name):
             ws_stop TEXT NOT NULL,
             web_statys INTEGER,
             fin_progress INTEGER,
+            b_city TEXT NOT NULL,
+            b_fin TEXT NOT NULL,
+            b_ban TEXT NOT NULL,
+            b_ign TEXT NOT NULL,
+            b_baners TEXT NOT NULL,
+            b_butt TEXT NOT NULL,
+            b_mess TEXT NOT NULL,           
             shop_statys_full TEXT NOT NULL,
             curator TEXT NOT NULL,
             pr1 TEXT NOT NULL,
@@ -212,19 +219,6 @@ def export_user():
 
 
 
-
-def send_second_request(export_id):
-    if export_id is None:
-        raise Exception("export_id is None")
-    # Формирование URL для второго запроса
-    export_url_template = f"https://school.riverpsy.com/pl/api/account/exports/{export_id}?key=jqgxSMUnHWoKUcxF3MHSb77VUMk7HpFbO9SHnfVYwHtwqe1S81lqeKxrLPoSPWCephtYQuJwMFsCXEFmyByXdruDpDFgf6L7ij66K9ji0Kf2qAIwbTqEyJGB5MOHwyHl"
-    try:
-        response = requests.get(export_url_template)
-        response.raise_for_status()
-        return response.json()  # Возвращаем JSON-ответ сервера
-    except requests.RequestException as e:
-        raise Exception(f"Ошибка при выполнении запроса: {e}")
-
 def load_data_from_json(json_data):
     if 'info' not in json_data or 'items' not in json_data['info'] or 'fields' not in json_data['info']:
         raise ValueError("Invalid JSON structure")
@@ -232,46 +226,56 @@ def load_data_from_json(json_data):
     items = json_data['info']['items']
     fields = json_data['info']['fields']
 
-    db = 'data_gc.db'  # Указываем конкретную базу данных
-    conn = sqlite3.connect(db)
-    cursor = conn.cursor()
+    for db in DATABASES:
+        conn = sqlite3.connect(db)
+        cursor = conn.cursor()
 
-    for item in items:
-        user_data = dict(zip(fields, item))
-        # Проверяем наличие значений для полей и устанавливаем значения по умолчанию, если они отсутствуют
-        user_data.setdefault('vk_id', '')
-        user_data.setdefault('chat_id', '')
-        user_data.setdefault('ws_st', '')
-        user_data.setdefault('ws_stop', '')
-        user_data.setdefault('web_st', '')
-        user_data.setdefault('fin_prog', '')
-        user_data.setdefault('shop_st', '')
-        user_data.setdefault('curator', '')
-        user_data.setdefault('pr1', '')
-        user_data.setdefault('pr2', '')
-        user_data.setdefault('pr3', '')
-        user_data.setdefault('pr4', '')
-        user_data.setdefault('pr5', '')
-        user_data.setdefault('ad_url', '')
-        user_data.setdefault('key_pr', '')
-        user_data.setdefault('n_con', '')        
-        user_data.setdefault('canal', '')
-        user_data.setdefault('data_t', '')
-        # Убираем плюс в начале телефона, если он присутствует
-        if 'Телефон' in user_data and user_data['Телефон'].startswith('+'):
-            user_data['Телефон'] = user_data['Телефон'][1:]
-
-        query = '''
-        INSERT INTO contacts (
-            name, phone, email, vk_id, chat_id, ws_statys, ws_stop, web_statys, fin_progress, shop_statys_full, pr1, pr2, pr3, pr4, pr5, ad_url, curator, key_pr, n_con, canal, data_t
-        ) VALUES (
-            :Имя, :Телефон, :Email, :vk_id, :chat_id, :ws_st, :ws_stop, :web_st, :fin_prog, :shop_st, :pr1, :pr2, :pr3, :pr4, :pr5, :ad_url, :curator, :key_pr, :n_con, :canal, :data_t
-        )
-        '''
-        cursor.execute(query, user_data)
+        for item in items:
+            user_data = dict(zip(fields, item))
+            # Проверяем наличие значений для полей и устанавливаем значения по умолчанию, если они отсутствуют
+            user_data.setdefault('vk_id', '')
+            user_data.setdefault('chat_id', '')
+            user_data.setdefault('ws_st', '')
+            user_data.setdefault('ws_stop', '')
+            user_data.setdefault('web_st', '')
+            user_data.setdefault('fin_prog', '')
+            user_data.setdefault('b_city', '')
+            user_data.setdefault('b_fin', '')
+            user_data.setdefault('b_ban', '')
+            user_data.setdefault('b_ign', '')
+            user_data.setdefault('b_baners', '')  
+            user_data.setdefault('b_butt', '')
+            user_data.setdefault('b_mess', '')   
+            user_data.setdefault('shop_st', '')
+            user_data.setdefault('curator', '')
+            user_data.setdefault('pr1', '')
+            user_data.setdefault('pr2', '')
+            user_data.setdefault('pr3', '')
+            user_data.setdefault('pr4', '')
+            user_data.setdefault('pr5', '')
+            user_data.setdefault('ad_url', '')
+            user_data.setdefault('key_pr', '')
+            user_data.setdefault('n_con', '')        
+            user_data.setdefault('canal', '')
+            user_data.setdefault('data_t', '')
+            # Убираем плюс в начале телефона, если он присутствует
+            if 'Телефон' in user_data and user_data['Телефон'].startswith('+'):
+                user_data['Телефон'] = user_data['Телефон'][1:]
+
+            # Создаем динамический запрос на основе полей в user_data
+            columns = ', '.join(user_data.keys())
+            placeholders = ', '.join(':' + key for key in user_data.keys())
+            query = f'''
+            INSERT INTO contacts (
+                {columns}
+            ) VALUES (
+                {placeholders}
+            )
+            '''
+            cursor.execute(query, user_data)
 
-    conn.commit()
-    conn.close()
+        conn.commit()
+        conn.close()
 
 @app.route('/start', methods=['GET'])
 def start():