Spaces:
Sleeping
Sleeping
File size: 2,263 Bytes
3f4e544 54b5657 2123df3 54b5657 18d4c31 54b5657 18d4c31 54b5657 e90fdaa 0827625 54b5657 dfc5447 bdbb93a e5a250e 54b5657 c134c84 9a9069e 54b5657 9a9069e c134c84 54b5657 e90fdaa 1ce6a36 54b5657 0827625 e44f507 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 |
from flask import request, jsonify
import os
import asyncio
import aiohttp
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
def add_user():
err = 0
if api_key == request.args.get('api'):
# Получаем данные из глобальных переменных
names = globs.name
emails = globs.email
phones = globs.phone
pr1s = globs.pr1
pr2s = globs.pr2
pr3s = globs.pr3
grups_id = globs.grup_id
# Создаем данные для отправки
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_add_user(data))
loop.close()
err = 1 if result == 200 else 0
response_data = {
"status": "success" if err == 1 else "error",
"err": err
}
return jsonify(response_data) |