feat: add temperature treshold

Author: An0nX

apps/auditing/events.py

@@ -9,4 +9,5 @@
     {"identifier": "ADMIN_LOGIN", "name": "Выполнен вход в панель администратора"},
     {"identifier": "DASHBOARD_VIEWED", "name": "Просмотрена панель мониторинга"},
     {"identifier": "DOS_DETECTED", "name": "Обнаружена DoS-атака"},
+    {"identifier": "TEMP_THRESHOLD_EXCEEDED", "name": "Превышен порог температуры"},
 ]

apps/sensor/admin.py

@@ -12,12 +12,13 @@ class SensorConfigAdmin(ModelAdmin, SingletonModelAdmin):
         "id",
         "period",
         "server_timeout",
+        "temperature_threshold",
         "log_rotation_days",
         "log_rotation_max_count",
         "device_pruning_days",
     )
     fieldsets = (
-        ("Настройки датчиков", {"fields": ("period", "server_timeout")}),
+        ("Настройки датчиков", {"fields": ("period", "server_timeout", "temperature_threshold")}),
         (
             "Ротация данных",
             {

apps/sensor/migrations/0004_sensorconfig_temperature_threshold.py

@@ -0,0 +1,18 @@
+# Generated by Django 5.2.6 on 2025-09-13 10:00
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('sensor', '0003_alter_temperaturereading_timestamp'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='sensorconfig',
+            name='temperature_threshold',
+            field=models.FloatField(blank=True, help_text='Если указано, будет отправлено уведомление при превышении этой температуры. Оставьте пустым, чтобы отключить.', null=True, verbose_name='Пороговое значение температуры (°C)'),
+        ),
+    ]

apps/sensor/migrations/0005_alter_sensorconfig_server_timeout.py

@@ -0,0 +1,18 @@
+# Generated by Django 5.2.7 on 2025-10-16 09:56
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('sensor', '0004_sensorconfig_temperature_threshold'),
+    ]
+
+    operations = [
+        migrations.AlterField(
+            model_name='sensorconfig',
+            name='server_timeout',
+            field=models.PositiveIntegerField(default=5, help_text='Запретить отправку данных чаще, чем раз в указанное количество секунд с одного IP. Например, значение 5 разрешит 1 запрос каждые 5 секунд. 0 - отключить ограничение.', verbose_name='Таймаут на стороне сервера'),
+        ),
+    ]

apps/sensor/models.py

@@ -23,6 +23,12 @@ class SensorConfig(SingletonModel):
         default=5,
         help_text="Запретить отправку данных чаще, чем раз в указанное количество секунд с одного IP. Например, значение 5 разрешит 1 запрос каждые 5 секунд. 0 - отключить ограничение.",
     )
+    temperature_threshold = models.FloatField(
+        verbose_name="Пороговое значение температуры (°C)",
+        null=True,
+        blank=True,
+        help_text="Если указано, будет отправлено уведомление при превышении этой температуры. Оставьте пустым, чтобы отключить.",
+    )
 
     # Data Rotation Settings
     log_rotation_days = models.PositiveIntegerField(

apps/sensor/views.py

@@ -116,9 +116,58 @@ class TemperatureDataAPIView(generics.CreateAPIView):
     serializer_class = TemperatureReadingSerializer
     throttle_classes = [DynamicSensorDataRateThrottle]
 
+    def _check_temperature_threshold(
+        self, reading: TemperatureReading, ip_address: str, device: Device
+    ) -> None:
+        """
+        Check if a temperature reading exceeds the configured threshold and log an event.
+
+        Args:
+            reading: The TemperatureReading instance to check.
+            ip_address: The IP address from which the reading was received.
+            device: The Device associated with the reading.
+        """
+        try:
+            config = SensorConfig.get_solo()
+            threshold = config.temperature_threshold
+
+            if threshold is None:
+                return
+
+            temps = [reading.contact_temp, reading.non_contact_temp]
+            valid_temps = [t for t in temps if t is not None]
+
+            if not valid_temps:
+                return
+
+            max_temp = max(valid_temps)
+
+            if max_temp > threshold:
+                event_logged.send(
+                    sender=self.__class__,
+                    event_identifier="TEMP_THRESHOLD_EXCEEDED",
+                    device=device,
+                    instance=reading,
+                    details={
+                        "ip_address": ip_address,
+                        "threshold": threshold,
+                        "measured_temp": max_temp,
+                        "contact_temp": reading.contact_temp,
+                        "non_contact_temp": reading.non_contact_temp,
+                    },
+                )
+        except SensorConfig.DoesNotExist:
+            # If config does not exist, we cannot check the threshold.
+            # This is unlikely with django-solo but handled for safety.
+            pass
+
     def perform_create(self, serializer: TemperatureReadingSerializer) -> None:
         """
-        Save the new TemperatureReading instance and log the event.
+        Save the new TemperatureReading instance, log events, and check for alerts.
+
+        This method saves the reading, logs the standard DATA_RECEIVED event,
+        and then checks if the temperature exceeds the globally configured
+        threshold, triggering a TEMP_THRESHOLD_EXCEEDED event if necessary.
 
         Args:
             serializer: The validated serializer instance containing the data.
@@ -128,6 +177,7 @@ def perform_create(self, serializer: TemperatureReadingSerializer) -> None:
 
         instance = serializer.save(device=device)
 
+        # Log the standard data reception event
         event_logged.send(
             sender=self.__class__,
             event_identifier="DATA_RECEIVED",
@@ -136,6 +186,9 @@ def perform_create(self, serializer: TemperatureReadingSerializer) -> None:
             details={"ip_address": ip_address, "payload": serializer.validated_data},
         )
 
+        # Check for temperature threshold alert
+        self._check_temperature_threshold(instance, ip_address, device)
+
 
 @extend_schema(
     tags=["sensor"],