Update google_db.py

google_db.py

@@ -1,22 +1,11 @@
 from flask import request, jsonify
 import os
-import asyncio
-import aiohttp
+import requests
+import globs
 
 api_key = os.getenv('api_key')
-base_url = os.getenv('base_url')
-token = os.getenv('token')
-list_id = os.getenv('list_id')
-parameter_id = os.getenv('parameter_id')
-
-async def async_add_user(data):
-    headers = {
-        'Authorization': f'Bearer {token}',
-        'Content-Type': 'application/json'
-    }
-    async with aiohttp.ClientSession() as session:
-        async with session.post(f"{base_url}lists/{list_id}/recipients", json=data, headers=headers) as response:
-            return response.status
+base_url = os.getenv('base_url')  # URL сервера, например, 'https://api.notisend.ru/v1/email/'
+token = os.getenv('token')  # Ваш токен
 
 def add_user():
     err = 0
@@ -26,45 +15,34 @@ def add_user():
         names = globs.name
         emails = globs.email
         phones = globs.phone
+        grups_id = globs.grup_id  # Это List ID
         pr1s = globs.pr1
         pr2s = globs.pr2
-        pr3s = globs.pr3
-        grups_id = globs.grup_id
 
         # Создаем данные для отправки
         data = {
+            'list_id': grups_id,
             'email': emails,
             'values': [
-                {
-                    'value': names,
-                    'parameter_id': parameter_id
-                },
-                {
-                    'value': phones,
-                    'parameter_id': parameter_id + 1  # Предполагаем, что есть уникальный ID для каждого параметра
-                },
-                {
-                    'value': pr1s,
-                    'parameter_id': parameter_id + 2
-                },
-                {
-                    'value': pr2s,
-                    'parameter_id': parameter_id + 3
-                },
-                {
-                    'value': pr3s,
-                    'parameter_id': parameter_id + 4
-                }
+                {'value': names, 'parameter_id': 'nam1'},
+                {'value': phones, 'parameter_id': 'pho2'},
+                {'value': pr1s, 'parameter_id': 'pr13'},
+                {'value': pr2s, 'parameter_id': 'pr24'}
             ]
         }
 
-        # Запускаем асинхронный запрос в отдельном потоке
-        loop = asyncio.new_event_loop()
-        asyncio.set_event_loop(loop)
-        result = loop.run_until_complete(async_add_user(data))
-        loop.close()
+        # Отправляем запрос
+        headers = {
+            'Authorization': f'Bearer {token}',
+            'Content-Type': 'application/json'
+        }
+        response = requests.post(f"{base_url}lists/{data['list_id']}/recipients", json=data, headers=headers)
+
+        # Сохраняем ответ от сервера в глобальную переменную
+        globs.server_response = response.text
 
-        err = 1 if result == 200 else 0
+        # Проверяем статус ответа
+        err = 1 if response.status_code == 200 else 0
 
     response_data = {
         "status": "success" if err == 1 else "error",