#!/usr/bin/env python3
"""
Service Plan — what Mesa's routing would look like if work were batched.
Mesa won't work on a live bus, so servicing any gen takes its whole group down
and every pod on it with it. The cost is therefore per SHUTDOWN, not per gen:
once the group is off, the second and third gen are nearly free. History says
we've been paying it one gen at a time — 827 group shutdowns to perform 919 PMs,
90% of them a single gen.
This page proposes the other way round. For each group it anchors a visit on the
soonest-due gen (you can never run past due), pulls in everything else in that
group coming due within the horizon, and adds the dated-free work — inspect
tags, notes, swaps — that can ride along for nothing.
READ-ONLY. It proposes; it books nothing. The horizon is adjustable in the URL
so the trade is visible: pulling a PM forward shifts that gen's cycle
permanently earlier, costing days_pulled/interval of an extra service, paid
against a pod shutdown avoided.
"""
import cgi
import cgitb
import html
import sys
sys.path.insert(0, '/opt/ngon/apps')
sys.path.insert(0, '/opt/ngon/apps/managers')
sys.path.insert(0, '/var/www/html/ngon')
from managers.auth_manager import AuthManager, generate_login_page_html, generate_access_denied_html
# NO nav dropdown here, deliberately — this page carries the mesa_gen_tracker
# access key, so Mesa can open it, and the Mesa Gen Tracker omits the standard
# menu for exactly that reason. The only link out is back to the tracker.
form = cgi.FieldStorage()
auth = AuthManager('mesa_gen_tracker')
auth_required, should_exit, headers = auth.require_auth(form)
if should_exit:
print("Content-Type: application/json")
if headers:
print(headers)
print("")
print('{"success": false, "error": "Authentication required"}' if auth_required
else '{"success": true}')
sys.exit(0)
cgitb.enable()
print("Content-Type: text/html; charset=utf-8")
print("Cache-Control: no-cache, no-store, must-revalidate")
print()
if auth_required:
print(generate_access_denied_html("Service Plan") if auth.is_authenticated()
else generate_login_page_html("Service Plan"))
sys.exit(0)
try:
horizon = float(form.getvalue('horizon') or 21)
except (TypeError, ValueError):
horizon = 21.0
horizon = max(0.0, min(90.0, horizon))
# Swaps are ours, not Mesa's — off unless explicitly asked for.
include_swaps = str(form.getvalue('swaps') or '').lower() in ('1', 'true', 'on', 'yes')
view = (form.getvalue('view') or 'site').lower()
if view not in ('site', 'week'):
view = 'site'
region = (form.getvalue('region') or 'all').upper()
if region not in ('ALL', 'ND', 'TX'):
region = 'ALL'
def url(**over):
"""This page's URL with one control changed and the rest kept — otherwise
switching the view silently resets your horizon and region."""
q = {'horizon': int(horizon), 'view': view, 'region': region.lower()}
if include_swaps:
q['swaps'] = 1
q.update(over)
q = {k: v for k, v in q.items() if v not in (None, '', 'all')}
return 'service_plan.py?' + '&'.join(f'{k}={v}' for k, v in q.items())
from generators import pm_service
plan = pm_service.build_plan(horizon_days=horizon, include_swaps=include_swaps)
t = plan.get('totals') or {}
# Median PM invoice across 900 costed visits in gen_service.db — used only to put
# a number on the horizon trade, not to make the decision.
PM_COST = 737
STATE_CLS = {'overdue': 'overdue', 'due': 'due', 'upcoming': 'upcoming', 'ok': 'ok'}
def _gen_statuses():
"""Maintenance-tag palette from master_config misc.display — the same source
constants_cgi.py serves to the browser and gen_manager.py reads, so a tag is
the same colour here, on the status page and on the Gen Tracker. Literal
below is the fallback if config is unreadable."""
fallback = {
'active': {'label': 'Active', 'color': '#00ff00', 'textColor': 'black'},
'active-swap': {'label': 'Active-Swap', 'color': '#ff6600', 'textColor': 'white'},
'swap': {'label': 'Swap', 'color': '#ff6600', 'textColor': 'white'},
'inspect': {'label': 'Inspect', 'color': '#ffaa00', 'textColor': 'black'},
'parts': {'label': 'Parts', 'color': '#ff4444', 'textColor': 'white'},
'gas': {'label': 'Gas', 'color': '#4a9eff', 'textColor': 'white'},
'oos': {'label': 'OOS', 'color': '#888888', 'textColor': 'white'},
}
try:
import json
with open('/opt/ngon/config/master_config.json') as f:
got = ((json.load(f).get('misc') or {}).get('display') or {}).get('genStatuses')
return got or fallback
except Exception:
return fallback
GEN_STATUSES = _gen_statuses()
print(f"""
Service Plan
Service Plan
What Mesa's routing would look like if the work were batched —
proposal only, nothing is booked from this page
Could not build a plan: {html.escape(plan["error"])}
')
print('
')
sys.exit(0)
saved = t.get('shutdowns_saved', 0)
extra = t.get('extra_pms', 0) or 0
print(f"""
{t.get('groups',0)}
groups with work
{t.get('pms',0)}
PMs batched
{t.get('inspects',0)}
inspects — {t.get('urgent_groups',0)} group(s) to visit now
{t.get('ride_along',0)}
ride-along items
{saved}
shutdowns avoided
{extra:g}
extra PMs ≈ ${extra*PM_COST:,.0f}
Batch horizon — how far forward work may be pulled:
""")
for h in (7, 14, 21, 30, 45):
on = ' class="on"' if abs(h - horizon) < 0.5 else ''
print(f' {h}d')
hidden = (plan.get('totals') or {}).get('swaps_hidden', 0)
print(' Swaps:')
print(f' hidden')
print(f' shown')
if not include_swaps and hidden:
print(f' ({hidden} swap-tagged gen'
f'{"s" if hidden != 1 else ""} left out)')
print('
')
print('
')
print(' Group by:')
for v, lbl in (('site', 'site — one trip, one place'), ('week', 'week — a calendar')):
print(f' {lbl}')
print(' Region:')
for rg, lbl in (('all', 'All'), ('nd', 'ND'), ('tx', 'TX')):
print(f' {lbl}')
print(f"""
A gen pulled {int(horizon)}d early loses {horizon/plan.get('interval_days',83)*100:.0f}%
of one interval · median PM ${PM_COST}
""")
def render_visit(g, show_site=False):
"""One proposed visit. Same markup in both views — only the grouping differs."""
d = g['visit_in_days']
cls = 'none' if d is None else ('now' if d <= 3 else ('soon' if d <= 14 else 'later'))
if g.get('urgent'):
cls = 'urgent'
week = f'week of {g["visit_week"][5:]}' if g['visit_week'] else 'no dated work'
label = f'{g["site"]} {g["group"]}' if show_site else g['group']
print(f'
')
print(f' {html.escape(label)}')
if not show_site:
print(f' {week}')
if d is not None and not show_site:
print(f' in {d}d')
if g.get('urgent'):
n = g.get('urgent_count', 0)
print(f' ⚠ {n} inspect{"s" if n != 1 else ""}')
if g['shutdowns_saved']:
print(f' saves {g["shutdowns_saved"]} shutdown'
f'{"s" if g["shutdowns_saved"] != 1 else ""}')
if g['days_pulled']:
print(f' · {g["days_pulled"]}d pulled forward '
f'= {g["extra_pm_cost"]:g} extra PM')
print(f' {g["miners"]:,} miners · {g["ph"]:g} PH/s')
print('
')
for i in g['pms']:
early = i['days_left'] - (g['visit_in_days'] or 0)
cls2 = STATE_CLS.get(i['state'], 'ok')
extra_txt = f'{early:.0f}d early' if early >= 1 else ''
print(f' '
f'PM {html.escape(i["gen"])} {extra_txt}')
# Inspects first: they're the reason a visit gets scheduled at all when no PM
# is due, so they shouldn't sort behind a pile of notes.
order = {'inspect': 0, 'parts': 1, 'active-swap': 2, 'swap': 3, 'gas': 4, 'oos': 5, 'note': 9}
for r in sorted(g['ride_along'], key=lambda x: (order.get(x['kind'], 8), x['gen'])):
tip = html.escape(r['detail'] or '', quote=True)[:160]
info = GEN_STATUSES.get(r['kind'])
if info:
style = (f'background:{info["color"]};color:{info.get("textColor","white")};'
f'border-color:{info["color"]};')
print(f' '
f'{html.escape(r["gen"])} · {html.escape(info["label"])}')
else:
# 'note' isn't a maintenance_status, so it has no fleet-wide colour.
print(f' {html.escape(r["gen"])} '
f'· note')
print('
')
if g['deferred']:
txt = ', '.join(f'{i["gen"]} ({i["days_left"]:.0f}d)' for i in g['deferred'])
print(f'
not in this visit at a {int(horizon)}d horizon: '
f'{html.escape(txt)}
')
print('
')
# Region is a scope, applied before anything is grouped or ranked, so the counts
# and the ordering both describe what you're actually looking at.
sites = [s for s in plan['sites'] if region == 'ALL' or s.get('region') == region]
visits = [g for s in sites for g in s['groups']]
if not visits:
print(f'
No outstanding work'
+ (f' in {html.escape(region)}' if region != 'ALL' else '') + '.
')
elif view == 'site':
# Biggest wins first — as a routing aid it should lead with the trips worth making.
for site in sorted(sites, key=lambda s: (-sum(1 for g in s['groups'] if g.get('urgent')),
-sum(g['shutdowns_saved'] for g in s['groups']),
s['site'])):
ssave = sum(g['shutdowns_saved'] for g in site['groups'])
spms = sum(len(g['pms']) for g in site['groups'])
surg = sum(g.get('urgent_count', 0) for g in site['groups'])
print(f'
')
for g in site['groups']:
render_visit(g)
print('
')
else:
# By week: the same visits on a calendar. A week is a TRIP-PLANNING unit —
# several groups landing in one week at one site is one drive, so the site
# name moves onto each row and the week becomes the heading.
from collections import defaultdict
buckets = defaultdict(list)
for g in visits:
buckets[g['visit_week']].append(g)
dated = sorted([w for w in buckets if w])
for wk in dated + ([None] if None in buckets else []):
rows = sorted(buckets[wk], key=lambda g: (not g.get('urgent'), g['site'], g['group']))
wsave = sum(g['shutdowns_saved'] for g in rows)
wpms = sum(len(g['pms']) for g in rows)
wmin = sum(g['miners'] for g in rows)
bysite = {}
for g in rows:
bysite.setdefault(g['site'], 0)
bysite[g['site']] += 1
trips = ', '.join(f'{k} ({v})' if v > 1 else k for k, v in sorted(bysite.items()))
head = f'Week of {wk}' if wk else 'No dated work'
print(f'