Update app.py

app.py

@@ -108,71 +108,67 @@ for db in DATABASES:
 
 
 
-# Флаг выполнения кода
 code_executed = False
 
 # Переменная для хранения данных
 export_data_var = None
 
-async def fetch(url):
-    async with httpx.AsyncClient() as client:
-        response = await client.get(url)
-        return response.json()
-
-async def get_export_id():
-    url_template = f"{gc_url_gru}/{id_gru}/users?key={gc_api}&created_at[from]={date_from}&status={status}"
-    data = await fetch(url_template)
-    if data.get("success"):
-        return data.get("info", {}).get("export_id", "")
-    else:
-        raise Exception(f"Ошибка в ответе от сервера: {data.get('error_message')}")
-
-async def get_export_data(export_id):
-    export_url_template = f"{gc_url_export}/{export_id}?key={gc_api}"
-    data = await fetch(export_url_template)
-    if data.get("success"):
-        return data
-    else:
-        raise Exception(f"Ошибка при выполнении второго запроса по export_id, статус код: {data.get('status_code')}")
+async def fetch(session, url):
+    async with session.get(url) as response:
+        return await response.json()
 
 async def main():
     global code_executed, export_data_var
 
-    if start_up == '1' and not code_executed:
-        try:
-            export_id = await get_export_id()
-            print("Export ID:", export_id)
-
-            # Задержка в 5 минут перед вторым запросом (в секундах)
-            time_delay = 5 * 60
-            print(f"Ждем {time_delay} секунд перед вторым запросом...")
-            await asyncio.sleep(time_delay)
+    print(f"start_up: {start_up}, code_executed: {code_executed}")
 
-            export_data = await get_export_data(export_id)
-            print("Полученные данные по export_id:", export_data)
-
-            # Сохранение данных в переменную
-            export_data_var = export_data
-
-            # Пример использования переменной export_data_var
-            # Здесь вы можете выполнять любые операции с данными
-            print("Пример использования переменной export_data_var:")
-            print(export_data_var)
-
-            code_executed = True  # Устанавливаем флаг выполнения кода
-        except Exception as e:
-            print(f"Ошибка: {e}")
+    if start_up == '1' and not code_executed:
+        print("start_up равен '1' и код еще не выполнялся.")
+        # Формирование URL для первого запроса
+        url_template = f"{gc_url_gru}/{id_gru}/users?key={gc_api}&created_at[from]={date_from}&status={status}"
+        print(f"URL первого запроса: {url_template}")
+
+        async with aiohttp.ClientSession() as session:
+            # Отправка первого запроса к серверу
+            data = await fetch(session, url_template)
+            print("Первый запрос отправлен.")
+
+            if data.get("success"):
+                export_id = data.get("info", {}).get("export_id", "")
+                print("Export ID:", export_id)
+
+                # Задержка в 5 минут перед вторым запросом (в секундах)
+                time_delay = 5 * 60
+                print(f"Ждем {time_delay} секунд перед вторым запросом...")
+                await asyncio.sleep(time_delay)
+
+                # Формирование URL для второго запроса по export_id
+                export_url_template = f"{gc_url_export}/{export_id}?key={gc_api}"
+                print(f"URL второго запроса: {export_url_template}")
+
+                # Отправка второго запроса к серверу по export_id
+                export_data = await fetch(session, export_url_template)
+                print("Второй запрос отправлен.")
+
+                if export_data.get("success"):
+                    print("Полученные данные по export_id:", export_data)
+
+                    # Сохранение данных в переменную
+                    export_data_var = export_data
+
+                    # Пример использования переменной export_data_var
+                    # Здесь вы можете выполнять любые операции с данными
+                    print("Пример использования переменной export_data_var:")
+                    print(export_data_var)
+
+                    code_executed = True  # Устанавливаем флаг выполнения кода
+                else:
+                    print(f"Ошибка при выполнении второго запроса по export_id, статус код: {export_data.get('status_code')}")
+            else:
+                print("Ошибка в ответе от сервера:", data.get("error_message"))
     else:
         print("Системная переменная start_up не равна '1' или код уже выполнялся при старте сервера.")
 
-app = Flask(__name__)
-
-@app.before_first_request
-def init_async():
-    asyncio.run(main())
-
-
-
 
 
 
@@ -1053,11 +1049,10 @@ def gc_db_email():
 
 
 
+if __name__ == '__main__':
+    asyncio.run(main())
+    app.run(host='0.0.0.0', port=int(os.environ.get('PORT', 7860)))
 
 
 
 
-
-
-if __name__ == '__main__':
-    app.run(host='0.0.0.0', port=int(os.environ.get('PORT', 7860)))