Update google_db.py

google_db.py

@@ -1,23 +1,29 @@
 from flask import request, jsonify
-import globs
 import os
 import asyncio
 import aiohttp
 
-api_variabl = os.getenv('api_key')
-google_url = os.getenv('goo_url')
+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_save_db(data):
+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(google_url, data=data, headers={'Content-Type': 'application/x-www-form-urlencoded'}) as response:
-            # Просто проверяем статус код, не ожидая тела ответа
-            return response.status == 200
+        async with session.post(f"{base_url}lists/{list_id}/recipients", json=data, headers=headers) as response:
+            return response.status
 
-def save_db():
+def add_user():
     err = 0
 
-    if api_variabl == request.args.get('api'):
-        names = globsname
+    if api_key == request.args.get('api'):
+        # Получаем данные из глобальных переменных
+        names = globs.name
         emails = globs.email
         phones = globs.phone
         pr1s = globs.pr1
@@ -25,19 +31,43 @@ def save_db():
         pr3s = globs.pr3
         grups_id = globs.grup_id
 
-
-        data = f"action=addData&grups_id={grups_id}&names={names}&emails={emails}&phones={phones}&pr1s={pr1s}&pr2s={pr2s}&pr3s={pr3s}"
+        # Создаем данные для отправки
+        data = {
+            '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
+                }
+            ]
+        }
 
         # Запускаем асинхронный запрос в отдельном потоке
         loop = asyncio.new_event_loop()
         asyncio.set_event_loop(loop)
-        result = loop.run_until_complete(async_save_db(data))
+        result = loop.run_until_complete(async_add_user(data))
         loop.close()
 
-        err = 1 if result else 0
+        err = 1 if result == 200 else 0
 
     response_data = {
-        "eep_set": globs.eep_set,
+        "status": "success" if err == 1 else "error",
         "err": err
     }