DBC22-4679: added weather station relations to cams (#1047)

Author: ray-oxd

src/backend/apps/feed/tasks.py

@@ -4,7 +4,7 @@
 from apps.event.tasks import populate_all_event_data
 from apps.ferry.tasks import populate_all_ferry_data, populate_coastal_ferry_data
 from apps.rest.tasks import populate_all_rest_stop_data
-from apps.shared.tasks import populate_all_district_data
+from apps.shared.tasks import populate_all_district_data, update_object_relations
 from apps.weather.tasks import (
     populate_all_high_elevation_forecast_data,
     populate_all_local_weather_data,
@@ -107,6 +107,12 @@ def update_districts():
     populate_all_district_data()
 
 
+@db_periodic_task(crontab(hour="*/24", minute="30", day_of_week="0"))
+@lock_task('relations-lock')
+def update_relations():
+    update_object_relations()
+
+
 @db_periodic_task(crontab(minute="*/20"))
 @lock_task('wildfires-lock')
 def update_wildfires():

src/backend/apps/shared/tasks.py

@@ -5,7 +5,7 @@
 from apps.feed.client import FeedClient
 from apps.shared.models import Area
 from apps.shared.serializers import DistrictSerializer
-from apps.webcam.tasks import update_camera_area_relations
+from apps.webcam.tasks import update_camera_relations
 from django.core.exceptions import ObjectDoesNotExist
 from email_log.models import Email
 from huey import crontab
@@ -42,9 +42,7 @@ def populate_all_district_data():
     for district_data in feed_data:
         populate_district_from_data(district_data)
 
-    update_area_relations()
 
-
-def update_area_relations():
-    update_camera_area_relations()
+def update_object_relations():
+    update_camera_relations()
     update_event_area_relations()

src/backend/apps/shared/test_urls.py

@@ -1,14 +1,14 @@
 from apps.event import views as event_views
 from apps.shared import views as shared_views
-from apps.webcam import views as webcam_views
+from apps.webcam import views as camera_views
 from django.urls import include, path
 from rest_framework import routers
 
 test_router = routers.DefaultRouter()
-test_router.register(r"webcams", webcam_views.WebcamTestViewSet,
-                     basename="test_webcams")
-test_router.register(r"delays", event_views.EventTestViewSet,
-                     basename="test_delays")
+test_router.register(r"cameras", camera_views.CameraViewSet,
+                     basename="test_cameras")
+test_router.register(r"events", event_views.EventTestViewSet,
+                     basename="test_events")
 
 urlpatterns = [
     path("", include(test_router.urls)),

src/backend/apps/webcam/migrations/0011_webcam_hev_station_webcam_local_weather_station_and_more.py

@@ -0,0 +1,51 @@
+# Generated by Django 4.2.22 on 2025-08-29 20:35
+
+import django.db.models.deletion
+from apps.webcam.tasks import update_camera_relations
+from django.db import migrations, models
+
+
+def update_relations(apps, schema_editor):
+    update_camera_relations()
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('weather', '0016_currentweather_code'),
+        ('webcam', '0010_webcam_group_webcam_nearby_objs'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='webcam',
+            name='hev_station',
+            field=models.ForeignKey(
+                blank=True,
+                null=True,
+                on_delete=django.db.models.deletion.SET_NULL,
+                to='weather.highelevationforecast'
+            ),
+        ),
+        migrations.AddField(
+            model_name='webcam',
+            name='local_weather_station',
+            field=models.ForeignKey(
+                blank=True,
+                null=True,
+                on_delete=django.db.models.deletion.SET_NULL,
+                to='weather.currentweather'
+            ),
+        ),
+        migrations.AddField(
+            model_name='webcam',
+            name='regional_weather_station',
+            field=models.ForeignKey(
+                blank=True,
+                null=True,
+                on_delete=django.db.models.deletion.SET_NULL,
+                to='weather.regionalweather'
+            ),
+        ),
+        migrations.RunPython(update_relations),
+    ]

src/backend/apps/webcam/models.py

@@ -1,4 +1,5 @@
 from apps.shared.models import Area, BaseModel
+from apps.weather.models import CurrentWeather, HighElevationForecast, RegionalWeather
 from django.contrib.gis.db import models
 
 
@@ -19,7 +20,12 @@ class Webcam(BaseModel):
     location = models.PointField()
     orientation = models.CharField(max_length=32, blank=True)
     elevation = models.PositiveSmallIntegerField()
+
+    # Foreign keys
     area = models.ForeignKey(Area, on_delete=models.SET_NULL, null=True, blank=False)
+    regional_weather_station = models.ForeignKey(RegionalWeather, on_delete=models.SET_NULL, null=True, blank=True)
+    local_weather_station = models.ForeignKey(CurrentWeather, on_delete=models.SET_NULL, null=True, blank=True)
+    hev_station = models.ForeignKey(HighElevationForecast, on_delete=models.SET_NULL, null=True, blank=True)
 
     # Relations
     group = models.ForeignKey("self", on_delete=models.SET_NULL, null=True, blank=True)

src/backend/apps/webcam/tasks.py

@@ -23,6 +23,7 @@
 from apps.webcam.models import Webcam
 from apps.webcam.serializers import WebcamSerializer
 from django.conf import settings
+from django.contrib.gis.db.models.functions import Distance
 from django.contrib.gis.geos import LineString, MultiLineString, Point
 from django.core.exceptions import ObjectDoesNotExist
 from django.db.models import F
@@ -341,10 +342,40 @@ def build_route_geometries(coords=hwy_coords):
             RouteGeometry.objects.filter(id=key).update(routes=MultiLineString(ls_routes))
 
 
-def update_camera_area_relations():
+# DBC22-4679 find and update the nearest weather stations for a camera
+def update_camera_weather_station(camera, weather_class):
+    meters_in_degrees = 0.000008983152841195  # 1 meter in degrees at the equator
+
+    stations_qs = weather_class.objects.filter(
+        location__dwithin=(camera.location, 30000 * meters_in_degrees),  # 30km in degrees
+        elevation__lte=camera.elevation + 300,
+        elevation__gte=camera.elevation - 300,  # within 300m elevation,
+    ) if isinstance(weather_class, CurrentWeather) else weather_class.objects.all()
+
+    closest_station = stations_qs.annotate(
+        distance=Distance('location', camera.location)
+    ).order_by('distance').first()
+
+    if closest_station:
+        if weather_class == CurrentWeather:
+            Webcam.objects.filter(id=camera.id).update(local_weather_station=closest_station)
+
+        elif weather_class == RegionalWeather:
+            Webcam.objects.filter(id=camera.id).update(regional_weather_station=closest_station)
+
+        elif weather_class == HighElevationForecast:
+            Webcam.objects.filter(id=camera.id).update(hev_station=closest_station)
+
+
+def update_camera_relations():
     for area in Area.objects.all():
         Webcam.objects.filter(location__within=area.geometry).update(area=area)
 
+    for camera in Webcam.objects.all():
+        update_camera_weather_station(camera, RegionalWeather)
+        update_camera_weather_station(camera, CurrentWeather)
+        update_camera_weather_station(camera, HighElevationForecast)
+
 
 def update_camera_group_id(camera):
     try:

src/backend/apps/webcam/urls.py

@@ -2,9 +2,9 @@
 from django.urls import include, path
 from rest_framework import routers
 
-webcam_router = routers.DefaultRouter()
-webcam_router.register(r"", webcam_views.WebcamViewSet, basename="webcams")
+camera_router = routers.DefaultRouter()
+camera_router.register(r"", webcam_views.CameraViewSet, basename="webcams")
 
 urlpatterns = [
-    path("", include(webcam_router.urls)),
+    path("", include(camera_router.urls)),
 ]

src/backend/apps/webcam/views.py

@@ -3,15 +3,6 @@
 from rest_framework import viewsets
 
 
-class WebcamAPI:
+class CameraViewSet(viewsets.ReadOnlyModelViewSet):
     queryset = Webcam.objects.filter(should_appear=True)
     serializer_class = WebcamSerializer
-
-
-class WebcamViewSet(WebcamAPI, viewsets.ReadOnlyModelViewSet):
-    pass
-
-
-class WebcamTestViewSet(viewsets.ReadOnlyModelViewSet):
-    queryset = WebcamAPI.queryset
-    serializer_class = WebcamAPI.serializer_class