Update app.py

app.py

@@ -1,53 +1,25 @@
-import sqlite3
-from flask import Flask, request
+from flask import Flask, request, render_template, jsonify
 import requests
 import os
 import pytz
 import datetime
+import sqlite3
 
 base_url = os.getenv('base_url')  # URL сервера
 token = os.getenv('token')  # Ваш токен
+api_key = os.getenv('api_key')  # Ваш API ключ
 
-app = Flask(__name__, template_folder="./")
-db_path = 'users.db'
-
-# Создаем соединение с базой данных SQLite3
-def create_connection():
-    conn = sqlite3.connect(db_path)
-    return conn
-
-# Инициализируем базу данных
-def init_db():
-    conn = create_connection()
-    c = conn.cursor()
-    # Создаем таблицу для пользователей, если она не существует
-    c.execute('''CREATE TABLE IF NOT EXISTS users (
-                 id INTEGER PRIMARY KEY AUTOINCREMENT,
-                 name TEXT,
-                 email TEXT,
-                 phone TEXT,
-                 pr5 TEXT,
-                 pr4 TEXT,
-                 pr3 TEXT,
-                 pr2 TEXT,
-                 pr1 TEXT,
-                 timestamp TEXT
-                 )''')
-    conn.commit()
-    conn.close()
+datas = '0'
+name = '0'
+email = '0'
+phone = '0'
 
-# Функция для вставки данных пользователя в базу данных
-def insert_form_data(name, email, phone, pr5, pr4, pr3, pr2, pr1):
-    conn = create_connection()
-    c = conn.cursor()
-    moscow_timezone = pytz.timezone('Europe/Moscow')
-    current_datetime = datetime.datetime.now(moscow_timezone)
-    timestamp = current_datetime.strftime('%Y-%m-%d %H:%M:%S')
-    c.execute('''INSERT INTO users (name, email, phone, pr5, pr4, pr3, pr2, pr1, timestamp)
-                 VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)''',
-              (name, email, phone, pr5, pr4, pr3, pr2, pr1, timestamp))
-    conn.commit()
-    conn.close()
+list_id_1 = 560768
+list_id_2 = 560832
+list_id_3 = 560833
+
+# Инициализация Flask приложения
+app = Flask(__name__, template_folder="./")
 
 # Функция для отправки запроса на сервер
 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):
@@ -64,40 +36,97 @@ def send_request(list_id, email, phone, name, param_name, param_phone, pr5, pr4,
             {"parameter_id": param_name, "kind": "string", "list_id": list_id, "title": "name", "value": name}
         ]
     }
-    headers = {'Authorization': f'Bearer {token}', 'Content-Type': 'application/json'}
+
+    headers = {
+        '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()
 
-# Инициализируем базу данных при запуске приложения
-init_db()
+# Функция для сохранения данных в SQLite3
+def save_to_database(name, email, phone, pr5, pr4, pr3, pr2, pr1):
+    conn = sqlite3.connect('users.db')
+    cur = conn.cursor()
+    # Создаем таблицу, если она не существует
+    cur.execute('''CREATE TABLE IF NOT EXISTS users
+                   (id INTEGER PRIMARY KEY AUTOINCREMENT,
+                    name TEXT,
+                    email TEXT,
+                    phone TEXT,
+                    pr5 TEXT,
+                    pr4 TEXT,
+                    pr3 TEXT,
+                    pr2 TEXT,
+                    pr1 TEXT,
+                    timestamp TIMESTAMP DEFAULT CURRENT_TIMESTAMP)''')
+    # Вставляем данные пользователя в таблицу
+    cur.execute('''INSERT INTO users (name, email, phone, pr5, pr4, pr3, pr2, pr1)
+                   VALUES (?, ?, ?, ?, ?, ?, ?, ?)''', (name, email, phone, pr5, pr4, pr3, pr2, pr1))
+    conn.commit()
+    conn.close()
 
-# Обработчик POST запроса на /incoming
+# Определение маршрута для обработки входящих POST-запросов
 @app.route('/incoming', methods=['POST'])
 def handle_incoming_request():
     datas = request.json
     name = datas.get('name')
     email = datas.get('email')
     phone = datas.get('phone')
+    
     pr5 = datas.get('pr5')
     pr4 = datas.get('pr4')
     pr3 = datas.get('pr3')
     pr2 = datas.get('pr2')
     pr1 = datas.get('pr1')
 
-    # Сохраняем данные пользователя в базу данных SQLite3
-    insert_form_data(name, email, phone, pr5, pr4, pr3, pr2, pr1)
+    # Устанавливаем временную зону Москвы
+    moscow_timezone = pytz.timezone('Europe/Moscow')
+
+    # Получаем текущую дату и время в Московском времени
+    current_datetime = datetime.datetime.now(moscow_timezone)
 
-    # Отправляем запросы в листы подряд
-    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)
+    # Получаем текущий день недели и час в Московском времени
+    current_day = current_datetime.weekday()  # 0 - Понедельник, ..., 6 - Воскресенье
+    current_hour = current_datetime.hour
 
-    # Возвращаем список ответов
-    return {'responses': [response_1, response_2, response_3]}
+    if current_day in [0, 4, 5, 6]:  # Понедельник, Пятница, Суббота, Воскресенье
+        # Отправляем запросы в листы подряд
+        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)
+        
+        # Сохраняем данные в базу данных SQLite3
+        save_to_database(name, email, phone, pr5, pr4, pr3, pr2, pr1)
+        
+        # Возвращаем список ответов
+        return {'responses': [response_2, response_3]}
+        
+    elif current_day == 1:  # Вторник
+        if current_hour < 19:
+            # Утром во вторник
+            # Комментарий: Отправка в лист 1, лист 2, лист 3
+            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)
+            
+            # Сохраняем данные в базу данных SQLite3
+            save_to_database(name, email, phone, pr5, pr4, pr3, pr2, pr1)
+            
+            # Возвращаем список ответов
+            return {'responses': [response_1, response_2, response_3]}
+        else:
+            # Вечером во вторник
+            # Комментарий: Отправка только лист 2, лист 3
+            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)
+            
+            # Сохраняем данные в базу данных SQLite3
+            save_to_database(name, email, phone, pr5, pr4, pr3, pr2, pr1)
+            
+            # Возвращаем список ответов
+            return {'responses': [response_2, response_3]}
 
-if __name__ == '__main__':
-    app.run(debug=True)
- 
 
         
     elif current_day == 1:  # Вторник