TMED-II Tracker

#!/usr/bin/env python3 """TMED-II Installation Tracker — minimal HTTP server with Jinja2 + MinIO photos.""" import sqlite3 import os import base64 import io from http.server import HTTPServer, BaseHTTPRequestHandler from urllib.parse import urlparse, parse_qs from jinja2 import Template from minio import Minio DB = os.path.join(os.path.dirname(os.path.abspath(__file__)), "tmed2_install.db") LOGO = "/home/borbolla/clawd/assets/branding/logo.png" PORT = 8877 # MinIO config MINIO_HOST = "192.168.100.251:9000" MINIO_KEY = "minioadmin" MINIO_SECRET = "minioadmin123" MINIO_BUCKET = "tmed2-photos" mc = Minio(MINIO_HOST, access_key=MINIO_KEY, secret_key=MINIO_SECRET, secure=False) # Encode logo with open(LOGO, "rb") as f: LOGO_B64 = base64.b64encode(f.read()).decode() TEMPLATE = Template("""\ TMED-II Tracker

{{ summary.machines }}

Machines

{{ summary.containers }}

Containers

{{ "%.0f"|format(summary.gross_t) }}T

Gross Weight

{{ summary.linked_photos }}

Photos Linked

{{ summary.received }}/{{ summary.machines }}

Received

{{ summary.commissioned }}/{{ summary.machines }}

Commissioned

Progress

{% for lp in line_progress %}

{{ lp.line }} {{ lp.total }} machines · {{ "%.0f"|format(lp.gross_t) }}T · {{ lp.arrival }}

{% for step in lp.steps %}

{{ step.label }}

{{ step.done }}/{{ lp.total }}

{% endfor %}

{% endfor %}

Machines

Containers

All Motor Case Assembly

{% for m in machines %} {% endfor %}

#	Line	Korean	English	T	Container	Arrival	Rcv	Inst	Elec	Air	Comm	Photos
{{ m.id }}	{{ m.line_short }}	{{ m.korean_name }}	{{ m.english_name[:45] }}{{ '...' if m.english_name\|length > 45 else '' }}	{{ "%.1f"\|format(m.weight_gross_t or 0) }}	{{ m.container_label or '—' }}	{{ m.arrival_group or '' }}	{{ 'Y'\|safe if m.received else '·'\|safe }}	{{ 'Y'\|safe if m.installed else '·'\|safe }}	{{ 'Y'\|safe if m.electrical else '·'\|safe }}	{{ 'Y'\|safe if m.air else '·'\|safe }}	{{ 'Y'\|safe if m.commissioned else '·'\|safe }}	{{ m.photo_count or '—' }}

{% for c in containers %} {% endfor %}

#	Container	Type	Line	Vessel	Sailing	Arrival	Day	Forklift	Items	Unloaded
{{ c.id }}	{{ c.supplier_prefix }}-{{ c.container_num }}	{{ c.container_type or '' }}	{{ c.line or '' }}	{{ (c.vessel or '')[:20] }}	{{ c.sailing_date or '' }}	{{ c.est_arrival or '' }}	{{ c.unload_day or '' }}	{{ c.forklift_class or '' }}	{{ c.machine_count }}	{{ 'Y'\|safe if c.unloaded else '·'\|safe }}

""") def query_db(): db = sqlite3.connect(DB) db.row_factory = sqlite3.Row c = db.cursor() summary = {} c.execute("SELECT count(*) FROM machines") summary["machines"] = c.fetchone()[0] c.execute("SELECT count(*) FROM containers") summary["containers"] = c.fetchone()[0] c.execute("SELECT coalesce(sum(weight_gross_t),0) FROM machines") summary["gross_t"] = c.fetchone()[0] c.execute("SELECT count(*) FROM machine_photos WHERE machine_id IS NOT NULL") summary["linked_photos"] = c.fetchone()[0] c.execute("SELECT coalesce(sum(received),0) FROM machines") summary["received"] = c.fetchone()[0] c.execute("SELECT coalesce(sum(commissioned),0) FROM machines") summary["commissioned"] = c.fetchone()[0] line_progress = [] c.execute(""" SELECT line, count(*) total, coalesce(sum(weight_gross_t),0) gross_t, sum(received) rcv, sum(installed) inst, sum(electrical) elec, sum(air) air, sum(commissioned) comm, min(arrival_group) arrival FROM machines GROUP BY line ORDER BY min(arrival_group) """) for row in c.fetchall(): css = "motor" if "Motor" in row["line"] else ("case" if "Case" in row["line"] else "assy") total = row["total"] steps = [ {"label": "Received", "done": row["rcv"] or 0, "pct": (row["rcv"] or 0) / total * 100, "css": "rcv"}, {"label": "Installed", "done": row["inst"] or 0, "pct": (row["inst"] or 0) / total * 100, "css": "inst"}, {"label": "Electrical", "done": row["elec"] or 0, "pct": (row["elec"] or 0) / total * 100, "css": "elec"}, {"label": "Air", "done": row["air"] or 0, "pct": (row["air"] or 0) / total * 100, "css": "air"}, {"label": "Commissioned", "done": row["comm"] or 0, "pct": (row["comm"] or 0) / total * 100, "css": "comm"}, ] line_progress.append({ "line": row["line"], "total": total, "gross_t": row["gross_t"], "arrival": row["arrival"], "css": css, "steps": steps, }) c.execute(""" SELECT m.*, c.supplier_prefix || '-' || c.container_num AS container_label, (SELECT count(*) FROM machine_photos p WHERE p.machine_id = m.id) AS photo_count FROM machines m LEFT JOIN containers c ON m.container_id = c.id ORDER BY m.arrival_group, m.line, m.id """) machines_list = [] for row in c.fetchall(): line = row["line"] or "" css = "motor" if "Motor" in line else ("case" if "Case" in line else "assy") short = "Motor" if "Motor" in line else ("Case" if "Case" in line else "Assy") machines_list.append({**dict(row), "line_css": css, "line_short": short}) c.execute(""" SELECT ct.*, (SELECT count(*) FROM machines m WHERE m.container_id = ct.id) AS machine_count FROM containers ct ORDER BY ct.est_arrival, ct.unload_day, ct.supplier_prefix, ct.container_num """) containers_list = [dict(row) for row in c.fetchall()] db.close() return summary, line_progress, machines_list, containers_list def get_photos_for_machine(machine_id): db = sqlite3.connect(DB) c = db.cursor() c.execute("SELECT minio_key FROM machine_photos WHERE machine_id = ?", (machine_id,)) photos = [{"key": row[0]} for row in c.fetchall()] db.close() return photos # Photo cache to avoid re-fetching from MinIO _photo_cache = {} def get_photo_bytes(minio_key): if minio_key in _photo_cache: return _photo_cache[minio_key] try: resp = mc.get_object(MINIO_BUCKET, minio_key) data = resp.read() resp.close() _photo_cache[minio_key] = data return data except Exception: return None class Handler(BaseHTTPRequestHandler): def do_GET(self): parsed = urlparse(self.path) path = parsed.path params = parse_qs(parsed.query) if path == "/photos": mid = int(params.get("machine_id", [0])[0]) photos = get_photos_for_machine(mid) import json self.send_response(200) self.send_header("Content-Type", "application/json") self.end_headers() self.wfile.write(json.dumps(photos).encode()) elif path.startswith("/photo/"): from urllib.parse import unquote minio_key = unquote(path[7:]) data = get_photo_bytes(minio_key) if data: ext = minio_key.rsplit(".", 1)[-1].lower() ct = {"png": "image/png", "jpg": "image/jpeg", "jpeg": "image/jpeg"}.get(ext, "image/jpeg") self.send_response(200) self.send_header("Content-Type", ct) self.send_header("Cache-Control", "max-age=86400") self.end_headers() self.wfile.write(data) else: self.send_response(404) self.end_headers() elif path == "/manifest": manifest_path = os.path.join(os.path.dirname(os.path.abspath(__file__)), "container_manifest.html") with open(manifest_path, "rb") as f: data = f.read() self.send_response(200) self.send_header("Content-Type", "text/html; charset=utf-8") self.end_headers() self.wfile.write(data) else: summary, line_progress, machines, containers = query_db() html = TEMPLATE.render( summary=summary, line_progress=line_progress, machines=machines, containers=containers, logo_b64=LOGO_B64, ) self.send_response(200) self.send_header("Content-Type", "text/html; charset=utf-8") self.end_headers() self.wfile.write(html.encode()) def log_message(self, fmt, *args): pass # quiet if __name__ == "__main__": print(f"TMED-II Tracker → http://0.0.0.0:{PORT}") HTTPServer(("0.0.0.0", PORT), Handler).serve_forever()