NGON Flowmeter Data

#!/usr/bin/env python3 import cgi, sys sys.path.insert(0, '/opt/ngon/apps') from managers.auth_manager import AuthManager, generate_login_page_html _form = cgi.FieldStorage() _auth = AuthManager('flowmeter') _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) if _auth_required: print("Content-Type: text/html") print("") print(generate_login_page_html("Flowmeter Data")) sys.exit(0) # --------------------------------------------------------------------------- import cgitb import html import json import time from datetime import date, timedelta cgitb.enable() sys.path.insert(0, '/var/www/html/ngon') from links import generate_dropdown_html, generate_dropdown_css, generate_dropdown_js from gas import flow_store FRESH_SEC = 120 # meter polls ~60s; flag a site live within 2 missed pushes sites = flow_store.sites_with_data() site = _form.getvalue('site', '') or (sites[0] if sites else '') if site and site not in sites: site = sites[0] if sites else '' today = date.today() date_to = _form.getvalue('to', '') or today.isoformat() date_from = _form.getvalue('from', '') or (today - timedelta(days=30)).isoformat() def _reading_age(r): if not r or r.get('ts') is None: return None return time.time() - float(r['ts']) # --- AJAX: live tile refresh ----------------------------------------------- if _form.getvalue('ajax', '') == 'live': print("Content-Type: application/json\n") r = flow_store.latest(site) if site else None age = _reading_age(r) out = {"has_data": bool(r), "site": site} if r: out.update({ "age_sec": round(age, 1) if age is not None else None, "fresh": age is not None and age < FRESH_SEC, "flow_mcfd": r.get("flow_mcfd"), "sp_psia": r.get("sp_psia"), "dp_inh2o": r.get("dp_inh2o"), "temp_f": r.get("temp_f"), "vol_today_mcf": r.get("vol_today_mcf"), "vol_yesterday_mcf": r.get("vol_yesterday_mcf"), }) print(json.dumps(out)) sys.exit(0) # --- CSV export ------------------------------------------------------------ if _form.getvalue('export', '') == 'csv' and site: rows = flow_store.daily_range(site, date_from, date_to) fname = f"flowmeter_{site}_{date_from}_to_{date_to}.csv".replace(' ', '_') print("Content-Type: text/csv") print(f"Content-Disposition: attachment; filename={fname}") print("") print("site,date,volume_mcf") for r in rows: print(f"{site},{r['day']},{r['vol_mcf']}") sys.exit(0) # --- HTML page ------------------------------------------------------------- rows = flow_store.daily_range(site, date_from, date_to) if site else [] total_mcf = sum((r['vol_mcf'] or 0) for r in rows) avg_mcf = (total_mcf / len(rows)) if rows else 0 live = flow_store.latest(site) if site else None live_age = _reading_age(live) live_fresh = live_age is not None and live_age < FRESH_SEC esc = html.escape print("Content-Type: text/html\n") site_options = "".join( f'' for s in sites ) or '' table_rows = "".join( f'{esc(r["day"])}{(r["vol_mcf"] or 0):,.2f}' for r in rows ) or 'No daily totals in this range.' print(f""" NGON Flowmeter Data

Live — {esc(site) or '(no site)'}

{(' LIVE · ' + (f'{int(live_age)}s ago' if live_age is not None else '')) if live_fresh else 'no live data'}

…

Daily Usage (accumulated volume per day)

{table_rows}

Date	Volume (MCF)

Days: {len(rows)} Total: {total_mcf:,.2f} MCF Avg/day: {avg_mcf:,.2f} MCF

""")

NGON Mining - Flowmeter Data

Live — {esc(site) or '(no site)'}