Update app.py

app.py

@@ -219,74 +219,65 @@ def export_user():
 
 
 
-def load_data_from_json(json_data):
-    # Debug print to inspect json_data
-    print(json.dumps(json_data, indent=4, ensure_ascii=False))
+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")
 
     items = json_data['info']['items']
     fields = json_data['info']['fields']
 
-    for db in DATABASES:
-        conn = sqlite3.connect(db)
-        cursor = conn.cursor()
+    db = 'data_gc.db'  # Указываем конкретную базу данных
+    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('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:]
-
-            query = '''
+    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, b_city, b_fin, b_ban, b_ign, b_baners, b_butt, b_mess, shop_st, 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, :b_city, :b_fin, :b_ban, :b_ign, :b_baners, :b_butt, :b_mess, :shop_st, :shop_st, :pr1, :pr2, :pr3, :pr4, :pr5, :ad_url, :curator, :key_pr, :n_con, :canal, :data_t
             )
             '''
-            cursor.execute(query, user_data)
-
-        conn.commit()
-        conn.close()
-
-
-
-
-
-
-
-
-
+        cursor.execute(query, user_data)
 
+    conn.commit()
+    conn.close()
 
 
 
@@ -299,15 +290,6 @@ def load_data_from_json(json_data):
 
 
 
-def send_second_request(export_id):
-    api_key = api_key_sys
-    api_url_template = 'https://school.riverpsy.com/pl/api/account/exports/{export_id}?key={api_key}'
-    api_url = api_url_template.format(export_id=export_id, api_key=api_key)
-    response = requests.get(api_url)
-    if response.status_code == 200:
-        return response.json()
-    else:
-        raise Exception(f"Failed to fetch data, status code: {response.status_code}")
 
 
 @app.route('/start', methods=['GET'])
@@ -316,18 +298,17 @@ def start():
     api_key_sys_control = request.args.get('api_sys')
 
     if export_id is None:
-        return jsonify({"error": "export_id is required"}), 400
+        return json.dumps({"error": "export_id is required"}), 400
 
     if api_key_sys_control != api_key_sys:
-        return jsonify({"error": "Unauthorized access"}), 403
+        return json.dumps({"error": "Unauthorized access"}), 403
 
     try:
         json_data = send_second_request(export_id)
-        print(json.dumps(json_data, indent=4, ensure_ascii=False))  # Debug print to inspect JSON data received
         load_data_from_json(json_data)
         return "Data loaded successfully", 200
     except Exception as e:
-        return jsonify({"error": str(e)}), 500
+        return json.dumps({"error": str(e)}), 500