Update app.py

app.py

@@ -1,25 +1,15 @@
 import flask
-from flask import request, jsonify, send_file
+from flask import request, jsonify
 import os
 import sqlite3
-import asyncio
-import aiohttp
+from datetime import datetime
 
 from dotenv import load_dotenv
 import globs
-from flask import render_template
-
-from datetime import datetime
-from api_logic import api
-
-
-
-
 
 load_dotenv()
 
-
-
+# Инициализация базы данных
 def init_db(db_name):
     conn = sqlite3.connect(db_name)
     cursor = conn.cursor()
@@ -54,8 +44,7 @@ def init_db(db_name):
     conn.commit()
     conn.close()
 
-
-
+# Глобальные переменные
 globs.dey = 0
 globs.wek = 0
 globs.v_hid = 0
@@ -76,7 +65,6 @@ globs.rSl = 0
 globs.rLe = 0
 globs.alW = 0
 
-
 globs.ph_eep = 0
 globs.ph_on_eep = 0
 globs.ec_eep = 0
@@ -89,49 +77,37 @@ globs.l_OFF_h_eep = 0
 globs.l_OFF_m_eep = 0
 globs.t_Voz_eep = 0
 
-
-
-
-
-
-
-
-
+# Создаем экземпляр Flask-приложения
 app = flask.Flask(__name__, template_folder="./")
 app.config['DEBUG'] = True
 
-
-
-
-
-
 # Функция сохранения в базу
 def save_data_to_db(db_name, data):
-    conn = sqlite3.connect(db_name)
-    cursor = conn.cursor()
-    
-    # Получаем текущую дату и время
-    current_time = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
-    
-    # Вставляем данные в таблицу
-    cursor.execute('''
-        INSERT INTO system_data (
-            date_time, dey, wek, v_hid, v_min, ph, ec, tS, tA, hDm, sVen, rFul, rLi, rWat, rRas, rPH, rEC, rSl, rLe, alW
-        ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
-    ''', (
-        current_time,  # Дата и время
-        data['dey'], data['wek'], data['v_hid'], data['v_min'], data['ph'], data['ec'],
-        data['tS'], data['tA'], data['hDm'], data['sVen'], data['rFul'], data['rLi'],
-        data['rWat'], data['rRas'], data['rPH'], data['rEC'], data['rSl'], data['rLe'], data['alW']
-    ))
-    
-    conn.commit()
-    conn.close()
-
-
-
-
-# Мвршрут сохранения в базу
+    try:
+        conn = sqlite3.connect(db_name)
+        cursor = conn.cursor()
+        
+        # Получаем текущую дату и время
+        current_time = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
+        
+        # Вставляем данные в таблицу
+        cursor.execute('''
+            INSERT INTO system_data (
+                date_time, dey, wek, v_hid, v_min, ph, ec, tS, tA, hDm, sVen, rFul, rLi, rWat, rRas, rPH, rEC, rSl, rLe, alW
+            ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
+        ''', (
+            current_time,  # Дата и время
+            data['dey'], data['wek'], data['v_hid'], data['v_min'], data['ph'], data['ec'],
+            data['tS'], data['tA'], data['hDm'], data['sVen'], data['rFul'], data['rLi'],
+            data['rWat'], data['rRas'], data['rPH'], data['rEC'], data['rSl'], data['rLe'], data['alW']
+        ))
+        
+        conn.commit()
+        conn.close()
+    except Exception as e:
+        return jsonify({'status': 'error', 'message': str(e)}), 500
+
+# Маршрут сохранения в базу
 @app.route('/sav_db_api', methods=['GET'])
 def sav_db_api():
     # Получаем данные из запроса
@@ -157,38 +133,43 @@ def sav_db_api():
         'alW': request.args.get('alW')
     }
     
+    # Проверяем, что все необходимые параметры переданы
+    required_params = ['dey', 'wek', 'v_hid', 'v_min', 'ph', 'ec', 'tS', 'tA', 'hDm', 'sVen', 'rFul', 'rLi', 'rWat', 'rRas', 'rPH', 'rEC', 'rSl', 'rLe', 'alW']
+    for param in required_params:
+        if data[param] is None:
+            return jsonify({'status': 'error', 'message': f'Отсутствует параметр: {param}'}), 400
+    
     # Сохраняем данные в базу
     save_data_to_db('system_data.db', data)
     
     # Возвращаем ответ
-    return jsonify(data)
-
-
-
-
+    return jsonify({'status': 'success', 'message': 'Данные сохранены'})
 
 # Маршрут для вывода всех данных из таблицы
 @app.route('/get_all_data', methods=['GET'])
 def get_all_data():
-    conn = sqlite3.connect('system_data.db')
-    cursor = conn.cursor()
-    
-    # Выполняем запрос для получения всех данных из таблицы
-    cursor.execute('SELECT * FROM system_data')
-    rows = cursor.fetchall()
-    
-    # Получаем названия столбцов
-    column_names = [description[0] for description in cursor.description]
-    
-    # Преобразуем данные в формат JSON
-    data = []
-    for row in rows:
-        data.append(dict(zip(column_names, row)))
-    
-    conn.close()
-    
-    # Возвращаем данные в формате JSON
-    return jsonify(data)
+    try:
+        conn = sqlite3.connect('system_data.db')
+        cursor = conn.cursor()
+        
+        # Выполняем запрос для получения всех данных из таблицы
+        cursor.execute('SELECT * FROM system_data')
+        rows = cursor.fetchall()
+        
+        # Получаем названия столбцов
+        column_names = [description[0] for description in cursor.description]
+        
+        # Преобразуем данные в формат JSON
+        data = []
+        for row in rows:
+            data.append(dict(zip(column_names, row)))
+        
+        conn.close()
+        
+        # Возвращаем данные в формате JSON
+        return jsonify(data)
+    except Exception as e:
+        return jsonify({'status': 'error', 'message': str(e)}), 500