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) or 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

@@ -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),

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">