feat(bus): fetch fcps afternoon bus delays

Closes #1413

Author: mktaher

intranet/apps/bus/migrations/0009_busdelay.py

@@ -0,0 +1,22 @@
+# Generated by Django 3.2.25 on 2025-05-20 23:50
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('bus', '0008_alter_busannouncement_message'),
+    ]
+
+    operations = [
+        migrations.CreateModel(
+            name='BusDelay',
+            fields=[
+                ('id', models.AutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
+                ('bus_number', models.CharField(max_length=10)),
+                ('reason', models.TextField()),
+                ('timestamp', models.DateTimeField(auto_now_add=True)),
+            ],
+        ),
+    ]

intranet/apps/bus/migrations/0010_auto_20250520_2301.py

@@ -0,0 +1,21 @@
+# Generated by Django 3.2.25 on 2025-05-21 03:01
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('bus', '0009_busdelay'),
+    ]
+
+    operations = [
+        migrations.DeleteModel(
+            name='BusDelay',
+        ),
+        migrations.AddField(
+            model_name='route',
+            name='reason',
+            field=models.CharField(blank=True, max_length=50),
+        ),
+    ]

intranet/apps/bus/models.py

@@ -10,12 +10,14 @@ class Route(models.Model):
     space = models.CharField(max_length=4, blank=True)
     bus_number = models.CharField(max_length=5, blank=True)
     status = models.CharField("arrival status", choices=ARRIVAL_STATUSES, max_length=1, default="o")
+    reason = models.CharField(max_length=50, blank=True)
 
     def reset_status(self):
         """Reset status to (on time)"""
         self.status = "o"
         self.space = ""
-        self.save(update_fields=["status", "space"])
+        self.reason = ""
+        self.save(update_fields=["status", "space", "reason"])
 
     def __str__(self):
         return self.route_name

intranet/apps/bus/tasks.py

@@ -1,5 +1,10 @@
+import requests
+from asgiref.sync import async_to_sync
+from bs4 import BeautifulSoup
 from celery import shared_task
 from celery.utils.log import get_task_logger
+from channels.layers import get_channel_layer
+from django.utils import timezone
 
 from .models import Route
 
@@ -12,3 +17,54 @@ def reset_routes() -> None:
 
     for route in Route.objects.all():
         route.reset_status()
+
+
+@shared_task
+def fetch_fcps_bus_delays():
+    now = timezone.localtime(timezone.now())
+    # Check if the current time is within 6-9 AM or 3-6 PM from Mon-Fri
+    if now.weekday() in (5, 6):
+        return
+    if not (now.hour in range(6, 9) and now.hour in range(15, 18)):
+        return
+    url = "https://busdelay.fcps.edu"
+    try:
+        response = requests.get(url, timeout=10)
+        response.raise_for_status()
+    except Exception as e:
+        logger.error("Error fetching URL: %s", e)
+        return
+
+    soup = BeautifulSoup(response.text, "html.parser")
+    rows = soup.select("table tr")
+    # In case a row is formatted incorrectly, check the amount of cells to make sure it contains all information
+    if not rows or len(rows) < 2:
+        logger.warning("Not a complete row with all bus information")
+        return
+    # Sort out the JEFFERSON HIGH bus delays
+    for row in rows[1:]:
+        cells = row.find_all("td")
+        if len(cells) >= 4 and cells[0].text.strip() == "JEFFERSON HIGH":
+            route_name = cells[1].text.strip().split()[0]
+            reason = cells[3].text.strip()
+            try:
+                obj = Route.objects.get(route_name=route_name)
+                # Only can update the status if it is on default status (on time)
+                if obj.status != "a":
+                    obj.status = "d"
+                    obj.reason = reason
+                    obj.save(update_fields=["status", "reason"])
+                    logger.info("Updated route %s with delay: %s", route_name, reason)
+                    channel_layer = get_channel_layer()
+                    all_routes = list(Route.objects.values())
+                    async_to_sync(channel_layer.group_send)(
+                        "bus",
+                        {
+                            "type": "bus.update",
+                            "message": {
+                                "allRoutes": all_routes,
+                            },
+                        },
+                    )
+            except Route.DoesNotExist:
+                logger.error("Route with route_name %s does not exist", route_name)

intranet/apps/bus/views.py

@@ -45,19 +45,21 @@ def afternoon(request, on_home=False):
         raise Http404("Bus app not enabled.")
     is_bus_admin = request.user.has_admin_permission("bus")
 
-    now = timezone.localtime()
+    current_time = timezone.localtime()
     day = Day.objects.today()
     if day is not None and day.end_time is not None:
-        end_of_day = day.end_time.date_obj(now.date())
+        end_of_day = day.end_time.date_obj(current_time.date())
     else:
-        end_of_day = datetime.datetime(now.year, now.month, now.day, settings.SCHOOL_END_HOUR, settings.SCHOOL_END_MINUTE)
-
+        end_of_day = datetime.datetime(current_time.year, current_time.month, current_time.day, settings.SCHOOL_END_HOUR, settings.SCHOOL_END_MINUTE)
+    bus_delays_queryset = Route.objects.filter(status="d")
+    bus_delays = {delay.route_name: {"reason": delay.reason} for delay in bus_delays_queryset}
     ctx = {
         "admin": is_bus_admin,
         "enable_bus_driver": True,
         "changeover_time": settings.BUS_PAGE_CHANGEOVER_HOUR,
         "school_end_hour": end_of_day.hour,
         "school_end_time": end_of_day.minute,
+        "bus_delays": bus_delays,
         "on_home": on_home,
     }
     return render(request, "bus/home.html", context=ctx)

intranet/settings/__init__.py

@@ -3,7 +3,7 @@
 import os
 import re
 import sys
-from typing import Any, Dict, List, Tuple  # noqa
+from typing import Any, Dict, List, Tuple
 
 import celery.schedules
 import pytz
@@ -12,7 +12,7 @@
 from sentry_sdk.integrations.django import DjangoIntegration
 from sentry_sdk.integrations.logging import LoggingIntegration
 
-from ..utils import helpers  # pylint: disable=wrong-import-position # noqa
+from ..utils import helpers  # pylint: disable=wrong-import-position
 
 if sys.version_info < (3, 5):
     # Require Python 3.5+
@@ -38,24 +38,24 @@
 
 # When school is scheduled to start and end
 SCHOOL_START_DATE = datetime.date(start_school_year,
-    8, 19  # UPDATE THIS! Value when last updated: August 19, 2024      # noqa: E128
-)                                                                       # noqa: E124
+    8, 19  # UPDATE THIS! Value when last updated: August 19, 2024
+)
 SCHOOL_END_DATE = datetime.date(end_school_year,
-    6, 11  # UPDATE THIS! Value when last updated: June 11, 2025        # noqa: E128
-)                                                                       # noqa: E124
+    6, 11  # UPDATE THIS! Value when last updated: June 11, 2025
+)
 
 # Dates when hoco starts and ends
 HOCO_START_DATE = datetime.date(start_school_year,
-    9, 21  # UPDATE THIS! Value when last updated: September 21, 2024   # noqa: E128
-)                                                                       # noqa: E124
+    9, 21  # UPDATE THIS! Value when last updated: September 21, 2024
+)
 HOCO_END_DATE = datetime.date(start_school_year,
-    9, 29  # UPDATE THIS! Value when last updated: September 29, 2024   # noqa: E128
-)                                                                       # noqa: E124
+    9, 29  # UPDATE THIS! Value when last updated: September 29, 2024
+)
 
 # Date of tjSTAR
 TJSTAR_DATE = datetime.date(end_school_year,
-    5, 21  # UPDATE THIS! Value when last updated: May 21, 2025         # noqa: E128
-)                                                                       # noqa: E124
+    5, 21  # UPDATE THIS! Value when last updated: May 21, 2025
+)
 
 # When to start showing the tjSTAR banner
 TJSTAR_BANNER_START_DATE = TJSTAR_DATE - datetime.timedelta(days=4)
@@ -955,6 +955,11 @@ def get_log(name):  # pylint: disable=redefined-outer-name; 'name' is used as th
         "schedule": celery.schedules.crontab(day_of_month=3, hour=1),
         "args": (),
     },
+    "fetch-fcps-bus-delays": {
+        "task": "intranet.apps.bus.tasks.fetch_fcps_bus_delays",
+        "schedule": 10.0,
+        "args": (),
+    },
     "remove-old-lostfound-entries": {
         "task": "intranet.apps.lostfound.tasks.remove_old_lostfound",
         "schedule": celery.schedules.crontab(day_of_month=1, hour=1),
@@ -992,7 +997,7 @@ def get_log(name):  # pylint: disable=redefined-outer-name; 'name' is used as th
 DEFAULT_AUTO_FIELD = "django.db.models.AutoField"
 
 try:
-    from .secret import *  # noqa
+    from .secret import *
 except ImportError:
     pass
 

intranet/templates/bus/home.html

@@ -113,6 +113,21 @@ <h2 class="bordered-element bus-announcement-header">
                 JT-100, JT100, jt-100, jt100, or 100.
             </p>
             {% endif %}
+            <div class="delay-announcements">
+                <h3>Current Bus Delays</h3>
+                {% if bus_delays %}
+                    {% for route, delay in bus_delays.items %}
+                        <div class="delay-card">
+                            <i class="fas fa-exclamation-triangle"></i>
+                            <span>
+                                <strong>Bus {{ route }}</strong> delayed due to: {{ delay.reason|lower }}
+                            </span>
+                        </div>
+                    {% endfor %}
+                {% else %}
+                    <p class="no-delays">No current delays reported.</p>
+                {% endif %}
+            </div>
         </div>
     </div>
     <script type="text/template" id="map-view">