450 lines
16 KiB
Python
450 lines
16 KiB
Python
|
# -*- coding: utf-8 -*-
|
|||
|
|
# LPC 0140650 web UI，运行于 Ubuntu 192.168.58.7:8090
|
|||
|
|
# LPC 自治架构：Modbus 轮询+闭环在 LPC Lua（触发器 #14/#15），本程序只做监控/记录/HTTP 转发
|
|||
|
|
import json
|
|||
|
|
import re
|
|||
|
|
import threading
|
|||
|
|
import time
|
|||
|
|
import urllib.request
|
|||
|
|
from http.server import BaseHTTPRequestHandler, ThreadingHTTPServer
|
|||
|
|
from urllib.parse import urlparse, parse_qs
|
|||
|
|
|
|||
|
|
LPC = "http://192.168.58.109"
|
|||
|
|
PORT = 8090
|
|||
|
|
HIST_FILE = "/home/tonycao/rs485-lpc/history.jsonl"
|
|||
|
|
SAMPLE_INTERVAL = 30 # 秒
|
|||
|
|
HIST_KEEP = 48 * 3600 # 48 小时
|
|||
|
|
|
|||
|
|
TRIG = {"BRT": 2, "LUX": 8, "LXT": 9, "LX2": 10, "FX": 11, "SC": 12,
|
|||
|
|
"FAD": 18, "PER": 19, "DBD": 20}
|
|||
|
|
TRIG_LINK_ON = 16
|
|||
|
|
TRIG_LINK_OFF = 17
|
|||
|
|
|
|||
|
|
_hist = [] # [[t_ms, brt, out, lux], ...] lux 可为 None
|
|||
|
|
_hist_lock = threading.Lock()
|
|||
|
|
_samples_since_compact = 0
|
|||
|
|
|
|||
|
|
def lpc_json(path):
|
|||
|
|
with urllib.request.urlopen(LPC + path, timeout=5) as r:
|
|||
|
|
return json.loads(r.read().decode("utf-8", "replace"))
|
|||
|
|
|
|||
|
|
def lpc_lua(names):
|
|||
|
|
d = lpc_json("/api/lua?variables=" + ",".join(names))
|
|||
|
|
return d
|
|||
|
|
|
|||
|
|
def lua_num(v):
|
|||
|
|
try:
|
|||
|
|
return int(round(float(v)))
|
|||
|
|
except Exception:
|
|||
|
|
return None
|
|||
|
|
|
|||
|
|
def read_lux():
|
|||
|
|
try:
|
|||
|
|
return lua_num(lpc_lua(["lux_value"]).get("lux_value"))
|
|||
|
|
except Exception:
|
|||
|
|
return None
|
|||
|
|
|
|||
|
|
def link_on():
|
|||
|
|
try:
|
|||
|
|
return bool(lpc_lua(["lux_link_on"]).get("lux_link_on"))
|
|||
|
|
except Exception:
|
|||
|
|
return False
|
|||
|
|
|
|||
|
|
def fire_trigger(num, var=None):
|
|||
|
|
url = LPC + "/api/trigger?num=%d" % num
|
|||
|
|
if var is not None:
|
|||
|
|
url += "&var=%d" % var
|
|||
|
|
req = urllib.request.Request(url, data=b"", method="POST")
|
|||
|
|
with urllib.request.urlopen(req, timeout=5) as r:
|
|||
|
|
r.read()
|
|||
|
|
|
|||
|
|
def sample_once():
|
|||
|
|
t = int(time.time() * 1000)
|
|||
|
|
brt = None
|
|||
|
|
out = None
|
|||
|
|
try:
|
|||
|
|
g = lpc_json("/api/group")
|
|||
|
|
brt = g["groups"][0]["level"]
|
|||
|
|
except Exception:
|
|||
|
|
pass
|
|||
|
|
try:
|
|||
|
|
o = lpc_json("/api/output?universe=dmx:1")
|
|||
|
|
vals = []
|
|||
|
|
for c in o["channels"][:32]:
|
|||
|
|
m = re.search(r"\d+", str(c))
|
|||
|
|
vals.append(int(m.group(0)) if m else 0)
|
|||
|
|
out = round(sum(vals) * 100.0 / (255 * len(vals)), 1)
|
|||
|
|
except Exception:
|
|||
|
|
pass
|
|||
|
|
lux = read_lux()
|
|||
|
|
row = [t, brt, out, lux]
|
|||
|
|
with _hist_lock:
|
|||
|
|
_hist.append(row)
|
|||
|
|
cutoff = t - HIST_KEEP * 1000
|
|||
|
|
while _hist and _hist[0][0] < cutoff:
|
|||
|
|
_hist.pop(0)
|
|||
|
|
try:
|
|||
|
|
with open(HIST_FILE, "a") as f:
|
|||
|
|
f.write(json.dumps(row, separators=(",", ":")) + "\n")
|
|||
|
|
except Exception:
|
|||
|
|
pass
|
|||
|
|
global _samples_since_compact
|
|||
|
|
_samples_since_compact += 1
|
|||
|
|
if _samples_since_compact >= 120: # 每小时压实一次文件
|
|||
|
|
_samples_since_compact = 0
|
|||
|
|
compact_history()
|
|||
|
|
|
|||
|
|
def compact_history():
|
|||
|
|
with _hist_lock:
|
|||
|
|
data = list(_hist)
|
|||
|
|
try:
|
|||
|
|
with open(HIST_FILE, "w") as f:
|
|||
|
|
for r in data:
|
|||
|
|
f.write(json.dumps(r, separators=(",", ":")) + "\n")
|
|||
|
|
except Exception:
|
|||
|
|
pass
|
|||
|
|
|
|||
|
|
def load_history():
|
|||
|
|
try:
|
|||
|
|
cutoff = int(time.time() * 1000) - HIST_KEEP * 1000
|
|||
|
|
with open(HIST_FILE) as f:
|
|||
|
|
for line in f:
|
|||
|
|
line = line.strip()
|
|||
|
|
if not line:
|
|||
|
|
continue
|
|||
|
|
try:
|
|||
|
|
r = json.loads(line)
|
|||
|
|
except Exception:
|
|||
|
|
continue
|
|||
|
|
if isinstance(r, list) and len(r) == 4 and r[0] >= cutoff:
|
|||
|
|
_hist.append(r)
|
|||
|
|
except Exception:
|
|||
|
|
pass
|
|||
|
|
|
|||
|
|
def sampler_loop():
|
|||
|
|
while True:
|
|||
|
|
try:
|
|||
|
|
sample_once()
|
|||
|
|
except Exception:
|
|||
|
|
pass
|
|||
|
|
time.sleep(SAMPLE_INTERVAL)
|
|||
|
|
|
|||
|
|
PAGE = r"""<!DOCTYPE html>
|
|||
|
|
<html lang="zh">
|
|||
|
|
<head>
|
|||
|
|
<meta charset="utf-8">
|
|||
|
|
<meta name="viewport" content="width=device-width, initial-scale=1">
|
|||
|
|
<title>LPC 灯光控制</title>
|
|||
|
|
<style>
|
|||
|
|
body{font-family:system-ui,"Microsoft YaHei",sans-serif;background:#111;color:#eee;margin:0;padding:12px;max-width:860px;margin:auto}
|
|||
|
|
h1{font-size:20px} h2{font-size:15px;color:#9cf;margin:14px 0 6px}
|
|||
|
|
.card{background:#1d1d1d;border-radius:10px;padding:12px;margin-bottom:12px}
|
|||
|
|
button{font-size:15px;padding:8px 14px;margin:4px;border:0;border-radius:8px;background:#2d6cdf;color:#fff;cursor:pointer}
|
|||
|
|
button.sc{background:#555}
|
|||
|
|
.row{display:flex;flex-wrap:wrap;align-items:center;gap:6px;margin:4px 0}
|
|||
|
|
.bars{display:grid;grid-template-columns:repeat(16,1fr);gap:4px}
|
|||
|
|
.ch{background:#333;border-radius:4px;text-align:center;font-size:10px;padding:2px 0}
|
|||
|
|
.ch .v{height:38px;display:flex;align-items:flex-end;justify-content:center}
|
|||
|
|
.ch .f{width:80%;border-radius:3px 3px 0 0;background:#fc3}
|
|||
|
|
.tl{display:flex;gap:8px;flex-wrap:wrap}
|
|||
|
|
.t{padding:6px 10px;border-radius:8px;background:#333;font-size:13px}
|
|||
|
|
.t.run{background:#1e5e1e}.t.rel{background:#5e1e1e}
|
|||
|
|
input[type=range]{width:220px}
|
|||
|
|
.sw{font-size:15px;padding:8px 14px;border-radius:8px;border:0;cursor:pointer;background:#555;color:#fff}
|
|||
|
|
.sw.on{background:#1e7e1e}
|
|||
|
|
#lux{font-size:24px;color:#fc3}
|
|||
|
|
.dim{color:#888;font-size:12px}
|
|||
|
|
canvas{width:100%;height:240px;background:#161616;border-radius:8px}
|
|||
|
|
.lg{display:inline-block;width:18px;height:3px;margin:0 5px 2px 12px;vertical-align:middle}
|
|||
|
|
</style>
|
|||
|
|
</head>
|
|||
|
|
<body>
|
|||
|
|
<h1>LPC 0140650 实时状态</h1>
|
|||
|
|
|
|||
|
|
<div class="card">
|
|||
|
|
<h2>照度联动</h2>
|
|||
|
|
<div class="row">
|
|||
|
|
<button id="luxsw" class="sw" onclick="luxlink()">…</button>
|
|||
|
|
<span>照度：<b id="lux">-</b> Lux</span>
|
|||
|
|
</div>
|
|||
|
|
<div class="row">目标照度：
|
|||
|
|
<input type="number" id="lxt" min="1" max="200000" step="10" style="width:90px"> Lux
|
|||
|
|
<button onclick="setlxt()">设定</button>
|
|||
|
|
</div>
|
|||
|
|
<div class="row">轮询周期：
|
|||
|
|
<input type="number" id="per" min="1" max="60" step="1" style="width:60px"> s
|
|||
|
|
<button onclick="setper()">设定</button>
|
|||
|
|
渐变时间：
|
|||
|
|
<input type="number" id="fad" min="0.1" max="10" step="0.1" style="width:60px"> s
|
|||
|
|
<button onclick="setfad()">设定</button>
|
|||
|
|
死区：
|
|||
|
|
<input type="number" id="dbd" min="1" max="1000" step="1" style="width:60px"> Lux
|
|||
|
|
<button onclick="setdbd()">设定</button>
|
|||
|
|
</div>
|
|||
|
|
<div class="dim">闭环在 LPC 内运行（触发器 #14 每秒轮询传感器，#15 Lua 自动调光）；轮询周期=闭环调节间隔，照度采集与显示仍每秒刷新；FAD 单位为 0.1s</div>
|
|||
|
|
</div>
|
|||
|
|
|
|||
|
|
<div class="card">
|
|||
|
|
<h2>控制</h2>
|
|||
|
|
<div class="row">效果：
|
|||
|
|
<button onclick="send('FX=01')">常亮</button>
|
|||
|
|
<button onclick="send('FX=02')">呼吸</button>
|
|||
|
|
<button onclick="send('FX=03')">闪烁</button>
|
|||
|
|
<button onclick="send('FX=04')">缓变</button>
|
|||
|
|
</div>
|
|||
|
|
<div class="row">场景：
|
|||
|
|
<button class="sc" onclick="send('SC=01')">全亮</button>
|
|||
|
|
<button class="sc" onclick="send('SC=02')">半亮</button>
|
|||
|
|
<button class="sc" onclick="send('SC=03')">微亮</button>
|
|||
|
|
<button class="sc" onclick="send('SC=04')">全灭</button>
|
|||
|
|
</div>
|
|||
|
|
<div class="row">总亮度：
|
|||
|
|
<input type="range" id="brt" min="0" max="100" value="100" onchange="brt()">
|
|||
|
|
<span id="brtv">100</span>%
|
|||
|
|
</div>
|
|||
|
|
</div>
|
|||
|
|
|
|||
|
|
<div class="card">
|
|||
|
|
<h2>历史曲线（48 小时，30s 采样）</h2>
|
|||
|
|
<canvas id="hist"></canvas>
|
|||
|
|
<div class="dim">
|
|||
|
|
<span class="lg" style="background:#fc3"></span>输出%（左轴 0-100）
|
|||
|
|
<span class="lg" style="background:#f80"></span>总调光 BRT%（左轴）
|
|||
|
|
<span class="lg" style="background:#3cf"></span>照度 Lux（右轴，对数 1-200k）
|
|||
|
|
<span id="histinfo"></span>
|
|||
|
|
</div>
|
|||
|
|
</div>
|
|||
|
|
|
|||
|
|
<div class="card">
|
|||
|
|
<h2>Timeline</h2>
|
|||
|
|
<div class="tl" id="tls"></div>
|
|||
|
|
</div>
|
|||
|
|
|
|||
|
|
<div class="card">
|
|||
|
|
<h2>DMX 输出（通道 1~32）</h2>
|
|||
|
|
<div class="bars" id="bars"></div>
|
|||
|
|
</div>
|
|||
|
|
|
|||
|
|
<div class="dim" id="ts"></div>
|
|||
|
|
|
|||
|
|
<script>
|
|||
|
|
const $=id=>document.getElementById(id);
|
|||
|
|
let luxOn=false, sending=false;
|
|||
|
|
|
|||
|
|
async function j(u){const r=await fetch(u);return r.json();}
|
|||
|
|
|
|||
|
|
async function refresh(){
|
|||
|
|
try{
|
|||
|
|
const tl=await j('/api/timeline');
|
|||
|
|
$('tls').innerHTML=tl.timelines.map(t=>
|
|||
|
|
`<div class="t ${t.state==='running'?'run':(t.state==='released'?'rel':'')}">T${t.num} ${t.name}<br>${t.state} ${(t.position/1000).toFixed(1)}s</div>`).join('');
|
|||
|
|
const out=await j('/api/output?universe=dmx:1');
|
|||
|
|
$('bars').innerHTML=out.channels.slice(0,32).map((c,i)=>{
|
|||
|
|
const v=parseInt(String(c).replace(/\D/g,''))||0;
|
|||
|
|
return `<div class="ch"><div class="v"><div class="f" style="height:${v/255*100}%"></div></div>${i+1}<br>${v}</div>`;}).join('');
|
|||
|
|
const g=await j('/api/group');
|
|||
|
|
const lv=g.groups[0].level;
|
|||
|
|
if(document.activeElement!==$('brt')){$('brt').value=lv;$('brtv').textContent=lv;}
|
|||
|
|
$('ts').textContent='更新于 '+new Date().toLocaleTimeString();
|
|||
|
|
}catch(e){$('ts').textContent='连接失败: '+e;}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
async function luxstat(){
|
|||
|
|
try{
|
|||
|
|
const s=await j('/luxlink');
|
|||
|
|
luxOn=s.on;
|
|||
|
|
$('luxsw').textContent=s.on?'联动中（点击关闭）':'已关闭（点击开启）';
|
|||
|
|
$('luxsw').className='sw'+(s.on?' on':'');
|
|||
|
|
if(s.lux!=null)$('lux').textContent=s.lux;
|
|||
|
|
if(s.target!=null&&document.activeElement!==$('lxt'))$('lxt').value=s.target;
|
|||
|
|
if(s.period!=null&&document.activeElement!==$('per'))$('per').value=s.period;
|
|||
|
|
if(s.fade!=null&&document.activeElement!==$('fad'))$('fad').value=(Math.round(s.fade*10)/10);
|
|||
|
|
if(s.deadband!=null&&document.activeElement!==$('dbd'))$('dbd').value=s.deadband;
|
|||
|
|
}catch(e){}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
async function setlxt(){const v=parseInt($('lxt').value);if(v>=1&&v<=200000)send('LXT='+v);}
|
|||
|
|
async function setper(){const v=parseInt($('per').value);if(v>=1&&v<=60)send('PER='+v);}
|
|||
|
|
async function setfad(){const v=Math.round(parseFloat($('fad').value)*10);if(v>=1&&v<=100)send('FAD='+v);}
|
|||
|
|
async function setdbd(){const v=parseInt($('dbd').value);if(v>=1&&v<=1000)send('DBD='+v);}
|
|||
|
|
|
|||
|
|
async function luxlink(){
|
|||
|
|
$('luxsw').textContent='切换中…';
|
|||
|
|
await fetch('/luxlink?on='+(luxOn?'0':'1'),{method:'POST'});
|
|||
|
|
setTimeout(luxstat,1500);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
async function send(c){
|
|||
|
|
if(sending)return; sending=true;
|
|||
|
|
await fetch('/send?cmd='+encodeURIComponent(c),{method:'POST'});
|
|||
|
|
sending=false; setTimeout(refresh,800); setTimeout(hist,5000);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function brt(){
|
|||
|
|
const v=$('brt').value; $('brtv').textContent=v;
|
|||
|
|
send('BRT='+String(v).padStart(3,'0'));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
const LUXMIN=1, LUXMAX=200000;
|
|||
|
|
function luxY(lux,h,pad){ // 对数轴
|
|||
|
|
const v=Math.max(LUXMIN,Math.min(LUXMAX,lux));
|
|||
|
|
const f=(Math.log10(v)-Math.log10(LUXMIN))/(Math.log10(LUXMAX)-Math.log10(LUXMIN));
|
|||
|
|
return h-pad-f*(h-2*pad);
|
|||
|
|
}
|
|||
|
|
function pctY(p,h,pad){ return h-pad-(p/100)*(h-2*pad); }
|
|||
|
|
|
|||
|
|
async function hist(){
|
|||
|
|
try{
|
|||
|
|
const d=await j('/history');
|
|||
|
|
const pts=d.points;
|
|||
|
|
const cv=$('hist');
|
|||
|
|
const w=cv.clientWidth, h=cv.clientHeight;
|
|||
|
|
const dpr=window.devicePixelRatio||1;
|
|||
|
|
cv.width=w*dpr; cv.height=h*dpr;
|
|||
|
|
const ctx=cv.getContext('2d'); ctx.scale(dpr,dpr);
|
|||
|
|
ctx.clearRect(0,0,w,h);
|
|||
|
|
const pad=28, now=Date.now(), t0=now-48*3600*1000;
|
|||
|
|
const X=t=>pad+(t-t0)/(now-t0)*(w-2*pad);
|
|||
|
|
|
|||
|
|
// 网格 + 时间刻度（每 6h）
|
|||
|
|
ctx.strokeStyle='#333'; ctx.fillStyle='#888'; ctx.font='10px sans-serif'; ctx.lineWidth=1;
|
|||
|
|
for(let k=0;k<=8;k++){
|
|||
|
|
const t=t0+k*6*3600*1000, x=X(t);
|
|||
|
|
ctx.beginPath(); ctx.moveTo(x,pad); ctx.lineTo(x,h-pad); ctx.stroke();
|
|||
|
|
const dt=new Date(t);
|
|||
|
|
ctx.fillText((dt.getMonth()+1)+'/'+dt.getDate()+' '+String(dt.getHours()).padStart(2,'0')+'时', x-24, h-8);
|
|||
|
|
}
|
|||
|
|
// 左轴 0/50/100%
|
|||
|
|
ctx.fillStyle='#fc3';
|
|||
|
|
[0,50,100].forEach(p=>{
|
|||
|
|
const y=pctY(p,h,pad);
|
|||
|
|
ctx.strokeStyle='#2a2a2a'; ctx.beginPath(); ctx.moveTo(pad,y); ctx.lineTo(w-pad,y); ctx.stroke();
|
|||
|
|
ctx.fillText(p+'%', 2, y+3);
|
|||
|
|
});
|
|||
|
|
// 右轴 lux 对数刻度
|
|||
|
|
ctx.fillStyle='#3cf';
|
|||
|
|
[1,10,100,1000,10000,100000,200000].forEach(l=>{
|
|||
|
|
const y=luxY(l,h,pad);
|
|||
|
|
ctx.fillText(l>=1000?(l/1000)+'k':l, w-pad+3, y+3);
|
|||
|
|
});
|
|||
|
|
if(!pts.length){ $('histinfo').textContent=' （暂无数据，采样中…）'; return; }
|
|||
|
|
|
|||
|
|
// 输出% 实线
|
|||
|
|
ctx.strokeStyle='#fc3'; ctx.lineWidth=1.5; ctx.beginPath();
|
|||
|
|
let started=false;
|
|||
|
|
for(const p of pts){
|
|||
|
|
if(p[2]==null){started=false;continue;}
|
|||
|
|
const x=X(p[0]), y=pctY(p[2],h,pad);
|
|||
|
|
started?ctx.lineTo(x,y):ctx.moveTo(x,y); started=true;
|
|||
|
|
}
|
|||
|
|
ctx.stroke();
|
|||
|
|
// BRT% 虚线
|
|||
|
|
ctx.strokeStyle='#f80'; ctx.setLineDash([4,3]); ctx.beginPath(); started=false;
|
|||
|
|
for(const p of pts){
|
|||
|
|
if(p[1]==null){started=false;continue;}
|
|||
|
|
const x=X(p[0]), y=pctY(p[1],h,pad);
|
|||
|
|
started?ctx.lineTo(x,y):ctx.moveTo(x,y); started=true;
|
|||
|
|
}
|
|||
|
|
ctx.stroke(); ctx.setLineDash([]);
|
|||
|
|
// lux 对数
|
|||
|
|
ctx.strokeStyle='#3cf'; ctx.lineWidth=1.5; ctx.beginPath(); started=false;
|
|||
|
|
for(const p of pts){
|
|||
|
|
if(p[3]==null){started=false;continue;}
|
|||
|
|
const x=X(p[0]), y=luxY(p[3],h,pad);
|
|||
|
|
started?ctx.lineTo(x,y):ctx.moveTo(x,y); started=true;
|
|||
|
|
}
|
|||
|
|
ctx.stroke();
|
|||
|
|
|
|||
|
|
const first=new Date(pts[0][0]);
|
|||
|
|
$('histinfo').textContent=` ${pts.length} 点，自 ${first.toLocaleString()}`;
|
|||
|
|
}catch(e){}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
refresh(); luxstat(); hist();
|
|||
|
|
setInterval(refresh,1500); setInterval(luxstat,6000); setInterval(hist,60000);
|
|||
|
|
window.addEventListener('resize', hist);
|
|||
|
|
</script>
|
|||
|
|
</body>
|
|||
|
|
</html>
|
|||
|
|
"""
|
|||
|
|
|
|||
|
|
class H(BaseHTTPRequestHandler):
|
|||
|
|
def _send(self, code, body, ctype="application/json; charset=utf-8"):
|
|||
|
|
b = body if isinstance(body, bytes) else body.encode("utf-8")
|
|||
|
|
self.send_response(code)
|
|||
|
|
self.send_header("Content-Type", ctype)
|
|||
|
|
self.send_header("Content-Length", str(len(b)))
|
|||
|
|
self.end_headers()
|
|||
|
|
self.wfile.write(b)
|
|||
|
|
|
|||
|
|
def log_message(self, *a):
|
|||
|
|
pass
|
|||
|
|
|
|||
|
|
def _reqlog(self):
|
|||
|
|
if self.command != "POST":
|
|||
|
|
return
|
|||
|
|
try:
|
|||
|
|
with open("/home/tonycao/rs485-lpc/lpc_web.req.log", "a") as f:
|
|||
|
|
f.write("%s %s %s %s\n" % (time.strftime("%F %T"),
|
|||
|
|
self.client_address[0], self.command, self.path))
|
|||
|
|
except Exception:
|
|||
|
|
pass
|
|||
|
|
|
|||
|
|
def do_GET(self):
|
|||
|
|
u = urlparse(self.path)
|
|||
|
|
if u.path in ("/", "/index.html"):
|
|||
|
|
self._send(200, PAGE, "text/html; charset=utf-8")
|
|||
|
|
elif u.path.startswith("/api/"):
|
|||
|
|
try:
|
|||
|
|
with urllib.request.urlopen(LPC + u.path + (("?" + u.query) if u.query else ""), timeout=5) as r:
|
|||
|
|
self._send(200, r.read(), "application/json")
|
|||
|
|
except Exception as e:
|
|||
|
|
self._send(502, json.dumps({"error": str(e)}))
|
|||
|
|
elif u.path == "/luxlink":
|
|||
|
|
cfg = {}
|
|||
|
|
try:
|
|||
|
|
d = lpc_lua(["lux_target", "lux_fade", "lux_poll_s", "lux_deadband"])
|
|||
|
|
cfg = {"target": lua_num(d.get("lux_target")),
|
|||
|
|
"fade": d.get("lux_fade"),
|
|||
|
|
"period": lua_num(d.get("lux_poll_s")),
|
|||
|
|
"deadband": lua_num(d.get("lux_deadband"))}
|
|||
|
|
except Exception:
|
|||
|
|
pass
|
|||
|
|
self._send(200, json.dumps({"on": link_on(), "lux": read_lux(), **cfg}))
|
|||
|
|
elif u.path == "/history":
|
|||
|
|
with _hist_lock:
|
|||
|
|
data = list(_hist)
|
|||
|
|
self._send(200, json.dumps({"points": data}, separators=(",", ":")))
|
|||
|
|
else:
|
|||
|
|
self._send(404, "{}")
|
|||
|
|
|
|||
|
|
def do_POST(self):
|
|||
|
|
self._reqlog()
|
|||
|
|
u = urlparse(self.path)
|
|||
|
|
q = parse_qs(u.query)
|
|||
|
|
if u.path == "/send":
|
|||
|
|
cmd = q.get("cmd", [""])[0]
|
|||
|
|
m = re.fullmatch(r"(BRT|FX|SC|LUX|LXT|LX2|FAD|PER|DBD)=(\d+)", cmd)
|
|||
|
|
if not m:
|
|||
|
|
self._send(400, json.dumps({"error": "bad cmd"}))
|
|||
|
|
return
|
|||
|
|
try:
|
|||
|
|
fire_trigger(TRIG[m.group(1)], int(m.group(2)))
|
|||
|
|
self._send(200, json.dumps({"ok": True}))
|
|||
|
|
except Exception as e:
|
|||
|
|
self._send(502, json.dumps({"error": str(e)}))
|
|||
|
|
elif u.path == "/luxlink":
|
|||
|
|
try:
|
|||
|
|
fire_trigger(TRIG_LINK_ON if q.get("on", ["0"])[0] == "1" else TRIG_LINK_OFF)
|
|||
|
|
self._send(200, json.dumps({"ok": True}))
|
|||
|
|
except Exception as e:
|
|||
|
|
self._send(502, json.dumps({"error": str(e)}))
|
|||
|
|
else:
|
|||
|
|
self._send(404, "{}")
|
|||
|
|
|
|||
|
|
if __name__ == "__main__":
|
|||
|
|
load_history()
|
|||
|
|
threading.Thread(target=sampler_loop, daemon=True).start()
|
|||
|
|
print("LPC web UI: http://0.0.0.0:%d (history %d pts)" % (PORT, len(_hist)))
|
|||
|
|
ThreadingHTTPServer(("0.0.0.0", PORT), H).serve_forever()
|