This commit is contained in:
Flatlogic Bot 2025-11-24 09:58:56 +00:00
parent cd996ba56a
commit 903669d6ea
39 changed files with 1023 additions and 79 deletions

0
.perm_test_apache Normal file
View File

0
.perm_test_exec Normal file
View File

3
ai/__init__.py Normal file
View File

@ -0,0 +1,3 @@
"""Helpers for interacting with the Flatlogic AI proxy from Django code."""
from .local_ai_api import LocalAIApi, create_response, request, decode_json_from_response # noqa: F401

420
ai/local_ai_api.py Normal file
View File

@ -0,0 +1,420 @@
"""
LocalAIApi lightweight Python client for the Flatlogic AI proxy.
Usage (inside the Django workspace):
from ai.local_ai_api import LocalAIApi
response = LocalAIApi.create_response({
"input": [
{"role": "system", "content": "You are a helpful assistant."},
{"role": "user", "content": "Summarise this text in two sentences."},
],
"text": {"format": {"type": "json_object"}},
})
if response.get("success"):
data = LocalAIApi.decode_json_from_response(response)
# ...
# Typical successful payload (truncated):
# {
# "id": "resp_xxx",
# "status": "completed",
# "output": [
# {"type": "reasoning", "summary": []},
# {"type": "message", "content": [{"type": "output_text", "text": "Your final answer here."}]}
# ],
# "usage": { "input_tokens": 123, "output_tokens": 456 }
# }
The helper automatically injects the project UUID header and falls back to
reading executor/.env if environment variables are missing.
"""
from __future__ import annotations
import json
import os
import time
import ssl
from typing import Any, Dict, Iterable, Optional
from urllib import error as urlerror
from urllib import request as urlrequest
__all__ = [
"LocalAIApi",
"create_response",
"request",
"fetch_status",
"await_response",
"extract_text",
"decode_json_from_response",
]
_CONFIG_CACHE: Optional[Dict[str, Any]] = None
class LocalAIApi:
"""Static helpers mirroring the PHP implementation."""
@staticmethod
def create_response(params: Dict[str, Any], options: Optional[Dict[str, Any]] = None) -> Dict[str, Any]:
return create_response(params, options or {})
@staticmethod
def request(path: Optional[str] = None, payload: Optional[Dict[str, Any]] = None,
options: Optional[Dict[str, Any]] = None) -> Dict[str, Any]:
return request(path, payload or {}, options or {})
@staticmethod
def extract_text(response: Dict[str, Any]) -> str:
return extract_text(response)
@staticmethod
def decode_json_from_response(response: Dict[str, Any]) -> Optional[Dict[str, Any]]:
return decode_json_from_response(response)
def create_response(params: Dict[str, Any], options: Optional[Dict[str, Any]] = None) -> Dict[str, Any]:
"""Signature compatible with the OpenAI Responses API."""
options = options or {}
payload = dict(params)
if not isinstance(payload.get("input"), list) or not payload["input"]:
return {
"success": False,
"error": "input_missing",
"message": 'Parameter "input" is required and must be a non-empty list.',
}
cfg = _config()
if not payload.get("model"):
payload["model"] = cfg["default_model"]
initial = request(options.get("path"), payload, options)
if not initial.get("success"):
return initial
data = initial.get("data")
if isinstance(data, dict) and "ai_request_id" in data:
ai_request_id = data["ai_request_id"]
poll_timeout = int(options.get("poll_timeout", 300))
poll_interval = int(options.get("poll_interval", 5))
return await_response(ai_request_id, {
"interval": poll_interval,
"timeout": poll_timeout,
"headers": options.get("headers"),
"timeout_per_call": options.get("timeout"),
})
return initial
def request(path: Optional[str], payload: Dict[str, Any], options: Optional[Dict[str, Any]] = None) -> Dict[str, Any]:
"""Perform a raw request to the AI proxy."""
cfg = _config()
options = options or {}
resolved_path = path or options.get("path") or cfg["responses_path"]
if not resolved_path:
return {
"success": False,
"error": "project_id_missing",
"message": "PROJECT_ID is not defined; cannot resolve AI proxy endpoint.",
}
project_uuid = cfg["project_uuid"]
if not project_uuid:
return {
"success": False,
"error": "project_uuid_missing",
"message": "PROJECT_UUID is not defined; aborting AI request.",
}
if "project_uuid" not in payload and project_uuid:
payload["project_uuid"] = project_uuid
url = _build_url(resolved_path, cfg["base_url"])
opt_timeout = options.get("timeout")
timeout = int(cfg["timeout"] if opt_timeout is None else opt_timeout)
verify_tls = options.get("verify_tls", cfg["verify_tls"])
headers: Dict[str, str] = {
"Content-Type": "application/json",
"Accept": "application/json",
cfg["project_header"]: project_uuid,
}
extra_headers = options.get("headers")
if isinstance(extra_headers, Iterable):
for header in extra_headers:
if isinstance(header, str) and ":" in header:
name, value = header.split(":", 1)
headers[name.strip()] = value.strip()
body = json.dumps(payload, ensure_ascii=False).encode("utf-8")
return _http_request(url, "POST", body, headers, timeout, verify_tls)
def fetch_status(ai_request_id: Any, options: Optional[Dict[str, Any]] = None) -> Dict[str, Any]:
"""Fetch status for a queued AI request."""
cfg = _config()
options = options or {}
project_uuid = cfg["project_uuid"]
if not project_uuid:
return {
"success": False,
"error": "project_uuid_missing",
"message": "PROJECT_UUID is not defined; aborting status check.",
}
status_path = _resolve_status_path(ai_request_id, cfg)
url = _build_url(status_path, cfg["base_url"])
opt_timeout = options.get("timeout")
timeout = int(cfg["timeout"] if opt_timeout is None else opt_timeout)
verify_tls = options.get("verify_tls", cfg["verify_tls"])
headers: Dict[str, str] = {
"Accept": "application/json",
cfg["project_header"]: project_uuid,
}
extra_headers = options.get("headers")
if isinstance(extra_headers, Iterable):
for header in extra_headers:
if isinstance(header, str) and ":" in header:
name, value = header.split(":", 1)
headers[name.strip()] = value.strip()
return _http_request(url, "GET", None, headers, timeout, verify_tls)
def await_response(ai_request_id: Any, options: Optional[Dict[str, Any]] = None) -> Dict[str, Any]:
"""Poll status endpoint until the request is complete or timed out."""
options = options or {}
timeout = int(options.get("timeout", 300))
interval = int(options.get("interval", 5))
if interval <= 0:
interval = 5
per_call_timeout = options.get("timeout_per_call")
deadline = time.time() + max(timeout, interval)
while True:
status_resp = fetch_status(ai_request_id, {
"headers": options.get("headers"),
"timeout": per_call_timeout,
"verify_tls": options.get("verify_tls"),
})
if status_resp.get("success"):
data = status_resp.get("data") or {}
if isinstance(data, dict):
status_value = data.get("status")
if status_value == "success":
return {
"success": True,
"status": 200,
"data": data.get("response", data),
}
if status_value == "failed":
return {
"success": False,
"status": 500,
"error": str(data.get("error") or "AI request failed"),
"data": data,
}
else:
return status_resp
if time.time() >= deadline:
return {
"success": False,
"error": "timeout",
"message": "Timed out waiting for AI response.",
}
time.sleep(interval)
def extract_text(response: Dict[str, Any]) -> str:
"""Public helper to extract plain text from a Responses payload."""
return _extract_text(response)
def decode_json_from_response(response: Dict[str, Any]) -> Optional[Dict[str, Any]]:
"""Attempt to decode JSON emitted by the model (handles markdown fences)."""
text = _extract_text(response)
if text == "":
return None
try:
decoded = json.loads(text)
if isinstance(decoded, dict):
return decoded
except json.JSONDecodeError:
pass
stripped = text.strip()
if stripped.startswith("```json"):
stripped = stripped[7:]
if stripped.endswith("```"):
stripped = stripped[:-3]
stripped = stripped.strip()
if stripped and stripped != text:
try:
decoded = json.loads(stripped)
if isinstance(decoded, dict):
return decoded
except json.JSONDecodeError:
return None
return None
def _extract_text(response: Dict[str, Any]) -> str:
payload = response.get("data") if response.get("success") else response.get("response")
if isinstance(payload, dict):
output = payload.get("output")
if isinstance(output, list):
combined = ""
for item in output:
content = item.get("content") if isinstance(item, dict) else None
if isinstance(content, list):
for block in content:
if isinstance(block, dict) and block.get("type") == "output_text" and block.get("text"):
combined += str(block["text"])
if combined:
return combined
choices = payload.get("choices")
if isinstance(choices, list) and choices:
message = choices[0].get("message")
if isinstance(message, dict) and message.get("content"):
return str(message["content"])
if isinstance(payload, str):
return payload
return ""
def _config() -> Dict[str, Any]:
global _CONFIG_CACHE # noqa: PLW0603
if _CONFIG_CACHE is not None:
return _CONFIG_CACHE
_ensure_env_loaded()
base_url = os.getenv("AI_PROXY_BASE_URL", "https://flatlogic.com")
project_id = os.getenv("PROJECT_ID") or None
responses_path = os.getenv("AI_RESPONSES_PATH")
if not responses_path and project_id:
responses_path = f"/projects/{project_id}/ai-request"
_CONFIG_CACHE = {
"base_url": base_url,
"responses_path": responses_path,
"project_id": project_id,
"project_uuid": os.getenv("PROJECT_UUID"),
"project_header": os.getenv("AI_PROJECT_HEADER", "project-uuid"),
"default_model": os.getenv("AI_DEFAULT_MODEL", "gpt-5-mini"),
"timeout": int(os.getenv("AI_TIMEOUT", "30")),
"verify_tls": os.getenv("AI_VERIFY_TLS", "true").lower() not in {"0", "false", "no"},
}
return _CONFIG_CACHE
def _build_url(path: str, base_url: str) -> str:
trimmed = path.strip()
if trimmed.startswith("http://") or trimmed.startswith("https://"):
return trimmed
if trimmed.startswith("/"):
return f"{base_url}{trimmed}"
return f"{base_url}/{trimmed}"
def _resolve_status_path(ai_request_id: Any, cfg: Dict[str, Any]) -> str:
base_path = (cfg.get("responses_path") or "").rstrip("/")
if not base_path:
return f"/ai-request/{ai_request_id}/status"
if not base_path.endswith("/ai-request"):
base_path = f"{base_path}/ai-request"
return f"{base_path}/{ai_request_id}/status"
def _http_request(url: str, method: str, body: Optional[bytes], headers: Dict[str, str],
timeout: int, verify_tls: bool) -> Dict[str, Any]:
"""
Shared HTTP helper for GET/POST requests.
"""
req = urlrequest.Request(url, data=body, method=method.upper())
for name, value in headers.items():
req.add_header(name, value)
context = None
if not verify_tls:
context = ssl.create_default_context()
context.check_hostname = False
context.verify_mode = ssl.CERT_NONE
try:
with urlrequest.urlopen(req, timeout=timeout, context=context) as resp:
status = resp.getcode()
response_body = resp.read().decode("utf-8", errors="replace")
except urlerror.HTTPError as exc:
status = exc.getcode()
response_body = exc.read().decode("utf-8", errors="replace")
except Exception as exc: # pylint: disable=broad-except
return {
"success": False,
"error": "request_failed",
"message": str(exc),
}
decoded = None
if response_body:
try:
decoded = json.loads(response_body)
except json.JSONDecodeError:
decoded = None
if 200 <= status < 300:
return {
"success": True,
"status": status,
"data": decoded if decoded is not None else response_body,
}
error_message = "AI proxy request failed"
if isinstance(decoded, dict):
error_message = decoded.get("error") or decoded.get("message") or error_message
elif response_body:
error_message = response_body
return {
"success": False,
"status": status,
"error": error_message,
"response": decoded if decoded is not None else response_body,
}
def _ensure_env_loaded() -> None:
"""Populate os.environ from executor/.env if variables are missing."""
if os.getenv("PROJECT_UUID") and os.getenv("PROJECT_ID"):
return
env_path = os.path.abspath(os.path.join(os.path.dirname(__file__), "..", ".env"))
if not os.path.exists(env_path):
return
try:
with open(env_path, "r", encoding="utf-8") as handle:
for line in handle:
stripped = line.strip()
if not stripped or stripped.startswith("#") or "=" not in stripped:
continue
key, value = stripped.split("=", 1)
key = key.strip()
value = value.strip().strip('\'"')
if key and not os.getenv(key):
os.environ[key] = value
except OSError:
pass

View File

@ -15,9 +15,12 @@ Including another URLconf
2. Add a URL to urlpatterns: path('blog/', include('blog.urls'))
"""
from django.contrib import admin
from django.urls import include, path
from django.urls import path, include
from core import views as core_views
urlpatterns = [
path("admin/", admin.site.urls),
path("", include("core.urls")),
path('admin/', admin.site.urls),
path('', core_views.dashboard, name='dashboard'),
path('', include('core.urls')),
]

View File

@ -1,8 +1,8 @@
from django.contrib import admin
from .models import Ticket
from .models import Unit
@admin.register(Ticket)
class TicketAdmin(admin.ModelAdmin):
list_display = ('subject', 'status', 'priority', 'requester_email', 'created_at')
list_filter = ('status', 'priority')
search_fields = ('subject', 'requester_email', 'description')
@admin.register(Unit)
class UnitAdmin(admin.ModelAdmin):
list_display = ('unit_id', 'unit_type', 'status', 'location_lat', 'location_lon')
list_filter = ('unit_type', 'status')
search_fields = ('unit_id',)

View File

@ -0,0 +1,10 @@
import os
def project_context(request):
"""
Adds project-specific environment variables to the template context globally.
"""
return {
"project_description": os.getenv("PROJECT_DESCRIPTION", ""),
"project_image_url": os.getenv("PROJECT_IMAGE_URL", ""),
}

View File

@ -1,7 +1,13 @@
from django import forms
from .models import Ticket
from .models import Unit
class TicketForm(forms.ModelForm):
class UnitForm(forms.ModelForm):
class Meta:
model = Ticket
fields = ['subject', 'requester_email', 'priority', 'description']
model = Unit
fields = ('location_lat', 'location_lon', 'status')
widgets = {
'location_lat': forms.NumberInput(attrs={'class': 'form-control'}),
'location_lon': forms.NumberInput(attrs={'class': 'form-control'}),
'status': forms.Select(attrs={'class': 'form-select'}),
}

View File

View File

View File

@ -0,0 +1,35 @@
import random
import time
from django.core.management.base import BaseCommand
from core.models import Unit
class Command(BaseCommand):
help = 'Starts the data simulation for emergency units.'
def handle(self, *args, **options):
self.stdout.write(self.style.SUCCESS('Starting simulation...'))
statuses = ['Available', 'Enroute', 'On Scene', 'Returning']
while True:
try:
units = Unit.objects.all()
for unit in units:
# Simulate location change
unit.location_lat += random.uniform(-0.01, 0.01)
unit.location_lon += random.uniform(-0.01, 0.01)
# Simulate status change
if random.random() < 0.1: # 10% chance to change status
unit.status = random.choice(statuses)
unit.save()
self.stdout.write(self.style.SUCCESS(f'Updated {len(units)} units.'))
time.sleep(5)
except KeyboardInterrupt:
self.stdout.write(self.style.WARNING('Simulation stopped by user.'))
break
except Exception as e:
self.stderr.write(self.style.ERROR(f'An error occurred: {e}'))
time.sleep(10) # Wait a bit before retrying

View File

@ -0,0 +1,30 @@
# Generated by Django 5.0.1 on 2024-01-26 12:00
from django.db import migrations, models
class Migration(migrations.Migration):
dependencies = [
('core', '0001_initial'),
]
operations = [
migrations.CreateModel(
name='Unit',
fields=[
('id', models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
('unit_id', models.CharField(max_length=100, unique=True)),
('unit_type', models.CharField(choices=[('Ambulance', 'Ambulance'), ('Police Car', 'Police Car')], max_length=50)),
('location_lat', models.FloatField(default=0.0)),
('location_lon', models.FloatField(default=0.0)),
('status', models.CharField(choices=[('Available', 'Available'), ('Dispatched', 'Dispatched'), ('Refueling', 'Refueling'), ('Out of Service', 'Out of Service')], default='Available', max_length=50)),
],
options={
'ordering': ['unit_id'],
},
),
migrations.DeleteModel(
name='Ticket',
),
]

View File

@ -0,0 +1,37 @@
# Generated by Django 5.0.1 on 2024-01-26 12:01
from django.db import migrations
import random
def create_initial_units(apps, schema_editor):
Unit = apps.get_model('core', 'Unit')
# 10 Ambulances
for i in range(1, 11):
Unit.objects.create(
unit_id=f'AMB-{i:03}',
unit_type='Ambulance',
location_lat=round(random.uniform(34.0, 35.0), 6),
location_lon=round(random.uniform(-118.0, -119.0), 6),
status='Available'
)
# 5 Police Cars
for i in range(1, 6):
Unit.objects.create(
unit_id=f'POL-{i:03}',
unit_type='Police Car',
location_lat=round(random.uniform(34.0, 35.0), 6),
location_lon=round(random.uniform(-118.0, -119.0), 6),
status='Available'
)
class Migration(migrations.Migration):
dependencies = [
('core', '0002_unit'),
]
operations = [
migrations.RunPython(create_initial_units),
]

Binary file not shown.

View File

@ -1,25 +1,25 @@
from django.db import models
class Ticket(models.Model):
class Unit(models.Model):
UNIT_TYPE_CHOICES = [
('Ambulance', 'Ambulance'),
('Police Car', 'Police Car'),
]
STATUS_CHOICES = [
('open', 'Open'),
('in_progress', 'In Progress'),
('closed', 'Closed'),
('Available', 'Available'),
('Dispatched', 'Dispatched'),
('Refueling', 'Refueling'),
('Out of Service', 'Out of Service'),
]
PRIORITY_CHOICES = [
('low', 'Low'),
('medium', 'Medium'),
('high', 'High'),
]
subject = models.CharField(max_length=255)
status = models.CharField(max_length=20, choices=STATUS_CHOICES, default='open')
priority = models.CharField(max_length=20, choices=PRIORITY_CHOICES, default='medium')
requester_email = models.EmailField()
description = models.TextField()
created_at = models.DateTimeField(auto_now_add=True)
updated_at = models.DateTimeField(auto_now=True)
unit_id = models.CharField(max_length=100, unique=True)
unit_type = models.CharField(max_length=50, choices=UNIT_TYPE_CHOICES)
location_lat = models.FloatField(default=0.0)
location_lon = models.FloatField(default=0.0)
status = models.CharField(max_length=50, choices=STATUS_CHOICES, default='Available')
def __str__(self):
return self.subject
return self.unit_id
class Meta:
ordering = ['unit_id']

50
core/templates/base.html Normal file
View File

@ -0,0 +1,50 @@
{% load static %}
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<meta name="viewport" content="width=device-width, initial-scale=1.0">
<title>{% block title %}{{ project_name|default:"Django Project" }}{% endblock %}</title>
<link href="https://cdn.jsdelivr.net/npm/bootstrap@5.3.0/dist/css/bootstrap.min.css" rel="stylesheet">
<link rel="preconnect" href="https://fonts.googleapis.com">
<link rel="preconnect" href="https://fonts.gstatic.com" crossorigin>
<link href="https://fonts.googleapis.com/css2?family=Lato:wght@400;700&family=Poppins:wght@700&display=swap" rel="stylesheet">
<link rel="stylesheet" href="{% static 'css/custom.css' %}">
</head>
<body>
<nav class="navbar navbar-expand-lg navbar-dark" style="background-color: var(--primary-color);">
<div class="container">
<a class="navbar-brand" href="{% url 'dashboard' %}">{{ project_name|default:"Project Lifeline" }}</a>
<button class="navbar-toggler" type="button" data-bs-toggle="collapse" data-bs-target="#navbarNav" aria-controls="navbarNav" aria-expanded="false" aria-label="Toggle navigation">
<span class="navbar-toggler-icon"></span>
</button>
<div class="collapse navbar-collapse" id="navbarNav">
<ul class="navbar-nav ms-auto">
<li class="nav-item">
<a class="nav-link" href="{% url 'dashboard' %}">Dashboard</a>
</li>
<li class="nav-item">
<a class="nav-link" href="{% url 'unit_list' %}">Units</a>
</li>
<li class="nav-item">
<a class="nav-link" href="{% url 'simulation_control' %}">Simulation</a>
</li>
</ul>
</div>
</div>
</nav>
<main class="container mt-4">
{% block content %}
{% endblock %}
</main>
<footer class="py-4 mt-5 bg-light text-center">
<div class="container">
<p class="mb-0 text-muted">&copy; {% now "Y" %} {{ project_name|default:"Project Lifeline" }}. All rights reserved.</p>
</div>
</footer>
<script src="https://cdn.jsdelivr.net/npm/bootstrap@5.3.0/dist/js/bootstrap.bundle.min.js"></script>
</body>
</html>

View File

@ -0,0 +1,14 @@
{% extends 'base.html' %}
{% block title %}{{ article.title }}{% endblock %}
{% block content %}
<div class="container mt-5">
<h1>{{ article.title }}</h1>
<p class="text-muted">Published on {{ article.created_at|date:"F d, Y" }}</p>
<hr>
<div>
{{ article.content|safe }}
</div>
</div>
{% endblock %}

View File

@ -0,0 +1,52 @@
{% extends 'base.html' %}
{% block title %}Dashboard | {{ project_name }}{% endblock %}
{% block content %}
<div class="page-header">
<h1 class="display-4">Dashboard</h1>
<p class="lead">Real-time operational overview of emergency response units.</p>
</div>
<div class="row">
<div class="col-lg-8 mb-4">
<div class="card h-100">
<div class="card-header">
<h5 class="card-title mb-0">Live Unit Map</h5>
</div>
<div class="card-body">
<div id="map-placeholder" class="bg-light" style="height: 500px; display: flex; align-items: center; justify-content: center;">
<p class="text-muted">Map visualization will be implemented here.</p>
</div>
</div>
</div>
</div>
<div class="col-lg-4 mb-4">
<div class="card">
<div class="card-header">
<h5 class="card-title mb-0">Key Performance Indicators</h5>
</div>
<div class="card-body">
<div class="kpi-grid">
<div class="kpi-card">
<h6>Avg. Response Time</h6>
<p class="kpi-value">-- min</p>
</div>
<div class="kpi-card">
<h6>Active Hotspots</h6>
<p class="kpi-value">--</p>
</div>
<div class="kpi-card">
<h6>Available Units</h6>
<p class="kpi-value">-- / 15</p>
</div>
<div class="kpi-card">
<h6>Dispatches (24h)</h6>
<p class="kpi-value">--</p>
</div>
</div>
</div>
</div>
</div>
</div>
{% endblock %}

View File

@ -0,0 +1,28 @@
{% extends 'base.html' %}
{% block content %}
<div class="container mt-5">
<div class="row">
<div class="col-md-8 offset-md-2">
<div class="card shadow-sm">
<div class="card-header bg-primary text-white">
<h4 class="mb-0">Data Simulation Control</h4>
</div>
<div class="card-body">
<p class="card-text">Use the controls below to start or stop the real-time data simulation. When running, unit locations and statuses will be updated automatically.</p>
<form method="post" class="mt-4">
{% csrf_token %}
{% if simulation_running %}
<button type="submit" name="stop" class="btn btn-danger btn-lg">Stop Simulation</button>
<span class="ms-3 text-success">Simulation is running.</span>
{% else %}
<button type="submit" name="start" class="btn btn-success btn-lg">Start Simulation</button>
<span class="ms-3 text-muted">Simulation is stopped.</span>
{% endif %}
</form>
</div>
</div>
</div>
</div>
</div>
{% endblock %}

View File

@ -0,0 +1,36 @@
{% extends 'base.html' %}
{% block title %}Edit Unit {{ unit.unit_id }} - {{ project_name }}{% endblock %}
{% block content %}
<div class="page-header">
<h1 class="display-5">Edit Unit: {{ unit.unit_id }}</h1>
<p class="lead">Update the status and location for this unit.</p>
</div>
<div class="row">
<div class="col-md-8 col-lg-6">
<div class="card shadow-sm">
<div class="card-body">
<form method="post">
{% csrf_token %}
<div class="mb-3">
<label for="{{ form.location_lat.id_for_label }}" class="form-label">Latitude</label>
{{ form.location_lat }}
</div>
<div class="mb-3">
<label for="{{ form.location_lon.id_for_label }}" class="form-label">Longitude</label>
{{ form.location_lon }}
</div>
<div class="mb-3">
<label for="{{ form.status.id_for_label }}" class="form-label">Status</label>
{{ form.status }}
</div>
<button type="submit" class="btn btn-primary">Save Changes</button>
<a href="{% url 'unit_list' %}" class="btn btn-secondary">Cancel</a>
</form>
</div>
</div>
</div>
</div>
{% endblock %}

View File

@ -0,0 +1,47 @@
{% extends 'base.html' %}
{% block title %}Unit Management - {{ project_name }}{% endblock %}
{% block content %}
<div class="page-header">
<h1 class="display-4">Unit & Resource Management</h1>
<p class="lead">Real-time status and location of all emergency response units.</p>
</div>
<div class="card shadow-sm">
<div class="card-body">
<div class="table-responsive">
<table class="table table-hover align-middle">
<thead>
<tr>
<th>Unit ID</th>
<th>Type</th>
<th>Status</th>
<th>Latitude</th>
<th>Longitude</th>
<th></th>
</tr>
</thead>
<tbody>
{% for unit in units %}
<tr>
<td><strong>{{ unit.unit_id }}</strong></td>
<td>{{ unit.unit_type }}</td>
<td><span class="badge bg-secondary">{{ unit.status }}</span></td>
<td>{{ unit.location_lat }}</td>
<td>{{ unit.location_lon }}</td>
<td class="text-end">
<a href="{% url 'unit_update' unit.pk %}" class="btn btn-primary btn-sm">Edit</a>
</td>
</tr>
{% empty %}
<tr>
<td colspan="6" class="text-center">No units found.</td>
</tr>
{% endfor %}
</tbody>
</table>
</div>
</div>
</div>
{% endblock %}

View File

@ -1,7 +1,10 @@
from django.urls import path
from .views import home
from . import views
urlpatterns = [
path("", home, name="home"),
path('dashboard/', views.dashboard, name='dashboard'),
path('simulation-control/', views.simulation_control, name='simulation_control'),
path('units/', views.unit_list, name='unit_list'),
path('units/<int:pk>/edit/', views.unit_update, name='unit_update'),
]

View File

@ -1,37 +1,65 @@
from django.shortcuts import render, redirect, get_object_or_404
from .models import Unit
from .forms import UnitForm
import subprocess
import os
import platform
import signal
from django import get_version as django_version
from django.shortcuts import render
from django.urls import reverse_lazy
from django.utils import timezone
from django.views.generic.edit import CreateView
SIMULATION_PID_FILE = 'simulation.pid'
from .forms import TicketForm
from .models import Ticket
def dashboard(request):
return render(request, 'core/dashboard.html', {'project_name': 'Project Lifeline'})
def simulation_control(request):
pid = None
if os.path.exists(SIMULATION_PID_FILE):
with open(SIMULATION_PID_FILE, 'r') as f:
try:
pid = int(f.read().strip())
# Check if the process is still running
os.kill(pid, 0)
except (ValueError, OSError):
pid = None
if os.path.exists(SIMULATION_PID_FILE):
os.remove(SIMULATION_PID_FILE)
def home(request):
"""Render the landing screen with loader and environment details."""
host_name = request.get_host().lower()
agent_brand = "AppWizzy" if host_name == "appwizzy.com" else "Flatlogic"
now = timezone.now()
if request.method == 'POST':
if 'start' in request.POST and not pid:
# Start the simulation
process = subprocess.Popen(['python3', 'manage.py', 'run_simulation'])
with open(SIMULATION_PID_FILE, 'w') as f:
f.write(str(process.pid))
pid = process.pid
return redirect('simulation_control')
elif 'stop' in request.POST and pid:
# Stop the simulation
try:
os.kill(pid, signal.SIGTERM)
if os.path.exists(SIMULATION_PID_FILE):
os.remove(SIMULATION_PID_FILE)
pid = None
except OSError:
# Process might have already died
if os.path.exists(SIMULATION_PID_FILE):
os.remove(SIMULATION_PID_FILE)
pid = None
return redirect('simulation_control')
context = {
"project_name": "New Style",
"agent_brand": agent_brand,
"django_version": django_version(),
"python_version": platform.python_version(),
"current_time": now,
"host_name": host_name,
"project_description": os.getenv("PROJECT_DESCRIPTION", ""),
"project_image_url": os.getenv("PROJECT_IMAGE_URL", ""),
}
return render(request, "core/index.html", context)
return render(request, 'core/simulation_control.html', {'simulation_running': pid is not None, 'project_name': 'Project Lifeline'})
class TicketCreateView(CreateView):
model = Ticket
form_class = TicketForm
template_name = "core/ticket_create.html"
success_url = reverse_lazy("home")
def unit_list(request):
units = Unit.objects.all()
return render(request, 'core/unit_list.html', {'units': units, 'project_name': 'Project Lifeline'})
def unit_update(request, pk):
unit = get_object_or_404(Unit, pk=pk)
if request.method == 'POST':
form = UnitForm(request.POST, instance=unit)
if form.is_valid():
form.save()
return redirect('unit_list')
else:
form = UnitForm(instance=unit)
return render(request, 'core/unit_form.html', {'form': form, 'unit': unit, 'project_name': 'Project Lifeline'})

100
static/css/custom.css Normal file
View File

@ -0,0 +1,100 @@
:root {
--primary-color: #0A2342;
--secondary-color: #2CA58D;
--background-color: #F0F4F8;
--highlight-color: #FFD700;
--text-color: #333;
--heading-font: 'Poppins', sans-serif;
--body-font: 'Lato', sans-serif;
}
body {
font-family: var(--body-font);
background-color: var(--background-color);
color: var(--text-color);
}
h1, h2, h3, h4, h5, h6 {
font-family: var(--heading-font);
color: var(--primary-color);
}
.navbar-brand {
font-family: var(--heading-font);
font-weight: 700;
color: #fff !important;
}
.nav-link {
color: rgba(255,255,255,0.8);
}
.nav-link:hover {
color: #fff;
}
.btn-primary {
background-color: var(--secondary-color);
border-color: var(--secondary-color);
}
.btn-primary:hover {
background-color: #248b75;
border-color: #248b75;
}
.table {
background-color: #fff;
}
.table thead {
background-color: var(--primary-color);
color: #fff;
}
.page-header {
padding: 2rem 0;
margin-bottom: 2rem;
}
.container {
max-width: 1200px;
}
.card {
border: none;
box-shadow: 0 0 20px rgba(0,0,0,0.05);
}
.form-label {
font-weight: bold;
}
/* Dashboard specific styles */
.kpi-grid {
display: grid;
grid-template-columns: repeat(2, 1fr);
gap: 1rem;
}
.kpi-card {
background-color: #fff;
padding: 1.5rem;
border-radius: 8px;
text-align: center;
box-shadow: 0 4px 12px rgba(0,0,0,0.08);
}
.kpi-card h6 {
font-size: 0.9rem;
color: var(--secondary-color);
margin-bottom: 0.5rem;
text-transform: uppercase;
}
.kpi-value {
font-size: 2rem;
font-weight: 700;
color: var(--primary-color);
margin-bottom: 0;
}

View File

@ -1,21 +1,63 @@
:root {
--bg-color-start: #6a11cb;
--bg-color-end: #2575fc;
--text-color: #ffffff;
--card-bg-color: rgba(255, 255, 255, 0.01);
--card-border-color: rgba(255, 255, 255, 0.1);
--primary-color: #0A2342;
--secondary-color: #2CA58D;
--background-color: #F0F4F8;
--highlight-color: #FFD700;
--text-color: #333;
--heading-font: 'Poppins', sans-serif;
--body-font: 'Lato', sans-serif;
}
body {
margin: 0;
font-family: 'Inter', sans-serif;
background: linear-gradient(45deg, var(--bg-color-start), var(--bg-color-end));
font-family: var(--body-font);
background-color: var(--background-color);
color: var(--text-color);
display: flex;
justify-content: center;
align-items: center;
min-height: 100vh;
text-align: center;
overflow: hidden;
position: relative;
}
h1, h2, h3, h4, h5, h6 {
font-family: var(--heading-font);
color: var(--primary-color);
}
.navbar-brand {
font-family: var(--heading-font);
font-weight: 700;
color: var(--primary-color) !important;
}
.btn-primary {
background-color: var(--secondary-color);
border-color: var(--secondary-color);
}
.btn-primary:hover {
background-color: #248b75;
border-color: #248b75;
}
.table {
background-color: #fff;
}
.table thead {
background-color: var(--primary-color);
color: #fff;
}
.page-header {
padding: 2rem 0;
margin-bottom: 2rem;
}
.container {
max-width: 1200px;
}
.card {
border: none;
box-shadow: 0 0 20px rgba(0,0,0,0.05);
}
.form-label {
font-weight: bold;
}