Update app.py

app.py

@@ -1,19 +1,15 @@
 from flask import Flask, request, jsonify
-import http.client
-import urllib.parse
+import requests
 import os
 import pytz
 import datetime
 import sqlite3
 
-tranid = '1228035:6425508451'
-formid = 'form770451882'
-
 base_url = os.getenv('base_url')  # URL сервера
-if not base_url:
-    base_url = 'https://webhook.site/7e9c68fe-4716-4c25-a547-8e3249522009'  # Замените на ваш действительный URL для отладки
+token = os.getenv('token')  # Ваш токен
+api_key = os.getenv('api_key')  # Ваш API ключ
 
-app = Flask(__name__, template_folder="./")
+app = Flask(__name__)
 
 def init_db():
     conn = sqlite3.connect('data.db')
@@ -56,39 +52,153 @@ def save_to_database(name, email, phone, pr5, pr4, pr3, pr2, pr1):
     except Exception as e:
         print(f"Error saving to database: {e}")
 
-def send_request(email, name, phone, tranid, formid, pr1, pr2, pr3, pr4, pr5):
+def send_request(list_id, email, phone, name, param_name, param_phone, pr5, pr4, pr3, pr2, pr1, pr5_id, pr4_id, pr3_id, pr2_id, pr1_id):
     """Функция для отправки запроса на сервер."""
     data = {
-        'Email': email,
-        'Name': name,
-        'Phone': phone,
-        'tranid': tranid,
-        'formid': formid,
-        'utm_source': pr1,
-        'utm_medium': pr2,
-        'utm_campaign': pr3,
-        'utm_content': pr4,
-        'utm_term': pr5
+        "email": email,
+        "unconfirmed": False,
+        "values": [
+            {
+                "parameter_id": pr5_id,
+                "kind": "string",
+                "list_id": list_id,
+                "title": "pr5",
+                "value": pr5
+            },
+            {
+                "parameter_id": pr4_id,
+                "kind": "string",
+                "list_id": list_id,
+                "title": "pr4",
+                "value": pr4
+            },
+            {
+                "parameter_id": pr3_id,
+                "kind": "string",
+                "list_id": list_id,
+                "title": "pr3",
+                "value": pr3
+            },
+            {
+                "parameter_id": pr2_id,
+                "kind": "string",
+                "list_id": list_id,
+                "title": "pr2",
+                "value": pr2
+            },
+            {
+                "parameter_id": pr1_id,
+                "kind": "string",
+                "list_id": list_id,
+                "title": "pr1",
+                "value": pr1
+            },
+            {
+                "parameter_id": param_phone,
+                "kind": "string",
+                "list_id": list_id,
+                "title": "phone",
+                "value": phone
+            },
+            {
+                "parameter_id": param_name,
+                "kind": "string",
+                "list_id": list_id,
+                "title": "name",
+                "value": name
+            }
+        ]
     }
 
     headers = {
-        'Content-Type': 'application/x-www-form-urlencoded'
+        'Authorization': f'Bearer {token}',
+        'Content-Type': 'application/json'
     }
+    response = requests.post(f"{base_url}/email/lists/{list_id}/recipients", json=data, headers=headers)
+    return response.json()
+
+def send_additional_request1(email, name, phone, pr1, pr2, pr3, pr4, pr5):
+    """Функция для отправки дополнительного запроса на другой адрес."""
+    data = {
+        "email": email,
+        "name": name,
+        "phone": phone,
+        "utm_source": pr1,
+        "utm_medium": pr2,
+        "utm_campaign": pr3,
+        "utm_content": pr4,
+        "utm_term": pr5,       
+    }
+
+    headers = {
+        'Content-Type': 'application/json'
+
+    }
+    response = requests.post('https://skyauto.me/cllbck/168704660/29237231/T1N1eVNQdy9LazBHNER2K3lldnA2Zz0?api=1&sid=535939344', data=data, headers=headers)
+    return response.json()
+
+
+
+def send_additional_request2(email, name, phone, pr1, pr2, pr3, pr4, pr5):
+    """Функция для отправки дополнительного запроса на другой адрес."""
+    data = {
+        "email": email,
+        "name": name,
+        "phone": phone,
+        "utm_source": pr1,
+        "utm_medium": pr2,
+        "utm_campaign": pr3,
+        "utm_content": pr4,
+        "utm_term": pr5,       
+    }
+
+    headers = {
+        'Content-Type': 'application/json'
+
+    }
+    response = requests.post('https://webhook.site/7e9c68fe-4716-4c25-a547-8e3249522009', data=data, headers=headers)
+    return response.json()
 
-    params = urllib.parse.urlencode(data)
 
-    try:
-        conn = http.client.HTTPSConnection(base_url)
-        conn.request("POST", "/", params, headers)
-        response = conn.getresponse()
-        response_data = response.read()
-        conn.close()
-        print(f"Response data: {response_data.decode('utf-8')}")
-        return response_data.decode('utf-8')
-    except Exception as e:
-        print(f"Error sending request: {e}")
-        return {"error": str(e)}
 
+def send_additional_request3(email, name, phone, pr1, pr2, pr3, pr4, pr5):
+    """Функция для отправки дополнительного запроса на другой адрес."""
+    data = {
+        "email": email,
+        "name": name,
+        "phone": phone,
+        "utm_source": pr1,
+        "utm_medium": pr2,
+        "utm_campaign": pr3,
+        "utm_content": pr4,
+        "utm_term": pr5,       
+    }
+
+    headers = {
+        'Content-Type': 'application/json'
+
+    }
+    response = requests.post('https://webhook.site/7e9c68fe-4716-4c25-a547-8e3249522009', data=data, headers=headers)
+    return response.json()
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+    
 @app.route('/incoming', methods=['POST'])
 def handle_incoming_request():
     datas = request.json
@@ -102,8 +212,6 @@ def handle_incoming_request():
     pr2 = datas.get('pr2')
     pr1 = datas.get('pr1')
 
-    print(f"Received data: {datas}")
-
     # Сохраняем данные в базу данных SQLite3
     save_to_database(name, email, phone, pr5, pr4, pr3, pr2, pr1)
 
@@ -119,11 +227,12 @@ def handle_incoming_request():
 
     if current_day in [0, 4, 5, 6]:  # Понедельник, Пятница, Суббота, Воскресенье
         # Отправляем запросы в листы подряд
-        response_1 = send_request(email, name, phone, tranid, formid, pr1, pr2, pr3, pr4, pr5)
-        print(f"Response: {response_1}")
-
+        response_1 = send_request(560768, email, phone, name, 393120, 393119, pr5, pr4, pr3, pr2, pr1, 393248, 393247, 393246, 393245, 393244)
+        response_2 = send_request(560832, email, phone, name, 393196, 393195, pr5, pr4, pr3, pr2, pr1, 393267, 393266, 393265, 393264, 393263)
+        response_3 = send_request(560833, email, phone, name, 393198, 393197, pr5, pr4, pr3, pr2, pr1, 393272, 393271, 393270, 393269, 393268)
+        response_4 = send_additional_request1(email, name, phone, pr1, pr2, pr3, pr4, pr5)
         # Возвращаем список ответов
-        return jsonify({'responses': [response_1]})
+        return jsonify({'responses': [response_1, response_2, response_3, response_4]})