5jxdZddlZddlZddlZddlZddlZddlmZmZddlm Z ddl m Z ddl Z ddl Zejj!ddZejj!ddZejj!d dZd eZejj!d d Zej,d Zej,dej0Zej,dej0ZdZdZdZdZdZdZ d>dZ!dZ"d?dZ#e e$jKjLdz Z'dddddddddddddd gd!Z(dZ)d"Z*d@d#Z+d$Z,d%Z-d&Z.d'Z/d(Z0d@d)Z1d@d*Z2d+Z3dAd,Z4d-Z5dAd.Z6ddddd/d0Z7d@d1Z8d2Z9d@d3Z:Gd4d5Z;iZd@d8Z?d9Z@e>e;d6d:dd;e#e2e+e(e1e)d<= y)Bu[ scada_report.py — SCADA daily-log report engine for Togen (DVI-482 / DVI-486). Self-contained extraction of the SCADA reporting engine that ST1 (DVI-482) first authored inside app.py. It is split out here so both the Flask app and the standalone scheduler (``scada_report_scheduler.py``, DVI-486) can build reports from a single source of truth without importing app.py — app.py spins up background loops at import time and is unsuitable for a one-shot cron/timer job (mirrors how ``notification_scheduler.py`` imports ``notifications.py``, never app.py). The engine reads daily X-400 "Log" emails from the SCADA mailbox via Microsoft Graph, parses their multi-row tables (columns derived per-email from the header row), bins rows by their parsed Date Time, and renders an XLSX workbook with one sheet per day. It is Flask-independent and configured purely from env vars, so it can be imported and unit-tested in isolation. Required env vars (same as app.py / notifications.py): AZURE_CLIENT_ID, AZURE_CLIENT_SECRET, AZURE_TENANT_ID Optional env var: SCADA_MAILBOX (default scadalogs@icastinc.com) N)datetime timedelta)Path)quoteAZURE_CLIENT_IDAZURE_CLIENT_SECRETAZURE_TENANT_IDz"https://login.microsoftonline.com/ SCADA_MAILBOXzscadalogs@icastinc.comz8^(\d{1,2})/(\d{1,2})/(\d{4})\s+(\d{1,2}):(\d{2}):(\d{2})z^\s*x-400\s*-\s*trigger\bz^\s*x-400\s*-\s*log\bch|xsd}tj|rytj|ryy)zClassify a SCADA email by subject line: 'log', 'trigger', or None. Routing both parsers off the subject keeps daily-log tables out of the Trigger-format status parser and vice-versa. rtriggerlogN)_SCADA_SUBJECT_TRIGGER_REmatch_SCADA_SUBJECT_LOG_RE)subjectss #/var/www/html/togen/scada_report.pyscada_subject_kindrCs2  2A &&q)""1% c<|jdixsi}|jddxsd}|jddjdk(xs'tjd|tjdu}|rtj dd |tj }tj d d |tj }tj d d |tj }tj dd|}t j|}|S)uReturn a daily-log email body as tab-delimited plain text. Converts HTML table markup to tabs/newlines so the same tab-delimited parser handles both HTML and text emails. bodyPreview is intentionally ignored — it truncates the multi-row table. bodycontentr contentTypehtmlz<(table|td|tr)\bNz  )flagsz z z<[^>]+>)getlowerresearchIsubrunescape)msgbody_objris_htmls r_scada_log_body_textr)Qswwvr"(bHll9b)/RG||M2.446&@L))/"$$?tK &&)4E&&,dG244H&&tWBDDA&&R1--( Nrcd|vrdSdS)uPick the cell delimiter for a log body: tab (HTML-converted) or comma. Real X-400 plain-text log emails are CSV ("Date Time,Vin(V),K1 Temp(F),...") — the original tab-only split left every line as one cell, which is what collapsed the XLSX report into a single column (DVI-1095). Tab wins when present so HTML-table bodies (converted to tabs by _scada_log_body_text) keep working even though their values never contain tabs. r,) body_texts r_scada_log_delimiterr.es9$4-#-rc t|}|j}g}|D][}|j|Dcgc]}|j}}|s2|dj dk(sI|Dcgc]}|s| }}ng}|D]}|j|}t j |dj}|s>|Dcgc]}|j} }t|} t| t| kr8| jdt| dzt| t| kr8tt| D cic] } | | | |  } } d|jD\} }}}}}t|| ||||| d<|j| "|s(|r&|djD cgc] } | dk7s |  }} ||dScc}wcc}wcc}wcc} w#ttf$rd| d<YmwxYwcc} w) aJParse a daily X-400 log email body into a delimited table (tab or CSV). Returns {"columns": [...], "rows": [...]}. Columns come verbatim from the email's header row ("Date Time | | Trigger"). Each row is a dict {col: value, ..., "_dt": datetime|None}. Missing readings ("x.x") are kept verbatim. rz date timeColumnc32K|]}t|ywNint.0gs r z)_parse_scada_log_email..s%Ac!f%A_dtN)columnsrows)r. splitlinessplitstripr _SCADA_LOG_DT_RErlistlenappendrangegroupsr ValueError TypeErrorkeys)r-delimlinesr<lineccellsr=mvaluescolskrowmodayrhhmmsss r_parse_scada_log_emailrZqs ! +E  "EG$(JJu$56q66 U1X^^%4"'-Q1q-G-   D 5!  " "58>>#3 4 %*+!'')++G}$i#f+% KK&TQ0 1$i#f+%+0V+=>atAwq !>> %Aahhj%A "BBB!"b"b"b9CJ C" t"1glln;U 1;; --37-,?I& CJ   H H(G?>G?cLtjdd|jS)zDStrip the unit suffix from a column name: 'K1 Temp(F)' -> 'K1 Temp'.z\s*\([^)]*\)\s*$r)r!r$r@)names r_scada_norm_sensorr]s 66%r4 0 6 6 88rc |jjdxsijdd}|xs|jddS#t$rd}Y wxYw)uShort human-readable message from a Graph error response body. Surfaced so callers can distinguish e.g. a tenant ApplicationAccessPolicy (RAOP) block from a missing Mail.Read grant (DVI-1095 P0 — the two need different admins to fix). errormessagerNi,)jsonr Exceptiontext)respr&s r_graph_error_messageresZyy{w'-2229bA  !$))DS/! s3A AAc  tjttt}|j dg}|j d}|sg|j ddfSg}|r|jd||r|jd|d td t|d |d } |r"| d tdj|dzz } d|dd} g} | rt| |krtj | | d} | jdk(rgdt| zfS| jdk7rgd| jdt| fS| j!} | j#| j dg| j d} | rt| |kr| Dcgc]"}t%|j dddk(r|$}}|d fScc}w#t&$r}gt)|fcYd }~Sd }~wwxYw)!a2Fetch daily-log mailbox messages (subject contains 'Log') with full body. Filters receivedDateTime server-side when a window is given; the subject match is client-side. Returns (messages, error); error is None on success, "403:" when mailbox access is denied, else a short string. ) authorityclient_credentialz$https://graph.microsoft.com/.default)scopes access_tokenerror_descriptionzno access_tokenzreceivedDateTime ge zreceivedDateTime le z'https://graph.microsoft.com/v1.0/users/z/messages?$top=z&$orderby=receivedDateTime z&&$select=subject,receivedDateTime,bodyz &$filter=z and  )safezBearer zapplication/json) Authorizationz Content-Type<)headerstimeoutiz403:z Graph API z: valuez@odata.nextLinkrrrN)msalConfidentialClientApplication _AZ_CLIENT_ID_AZ_AUTHORITY_HOME _AZ_SECRETacquire_token_for_clientrrDr r5rjoinrC_http_requests status_codereraextendrrbstr) received_ge received_le page_sizeorder max_messages app_client token_resulttokenfiltersurlrpmsgsrddatarOlog_msgsexcs r_scada_fetch_log_messagesrs%&77 %7:W !:::;;=   0|''(;=NOO O  NN1+? @  NN1+? @8HI''B5'78  ;w||G'<3!GG GC&-eW$5GYZc$i,.!%%c7BGD3&6$8$>>>>3&Z(8(8'9?5HJJ~J 3s8|sJAG B;G+GAGG'G G G G1 G,&G1,G1ctddd\}}|s|syg}|D]5}tt|}|jd|dD|s5n|r't |j j S|djdd } tj|jd d j j S#ttf$rYywxYw) zEarliest log day available in the mailbox (capped by retention), or None. Surfaced so the report filter UI (ST2) can bound its date picker. ascd)rrrNc3JK|]}|jds|dyw)r;N)r)r7rs rr9z+_scada_earliest_log_date..sDquuU|1U8Ds# #r=rreceivedDateTimerZz+00:00) rrZr)r}mindate isoformatrr fromisoformatreplacerGAttributeError)rerrdtsr&parsedreceiveds r_scada_earliest_log_daters *SVWID# $ C'(z%_build_scada_report..3s QuXrkeyrrr<r=)ryearmonthdaystrftimerrrZr)rr setdefaultrDnextiterrPrIrCr]r@rBsortedrr) date_fromdate_tosensorsrrwidenedrrnative_columnsby_dayr&rrSdtrsamplerRmiddlerM availablerwanted keep_middle out_columnsrrday_rowsrcoltables r_build_scada_reportrs!%$K+y~~y !!)*>!? 7<< DQ &&';< )k{[ID# r!%AE EN F 3'( 3CBz'')CS9_3=   c2 & - -c 2 3 3 fd6==?+,Q/%+[[]Aa5j!AA&)%8A%=^Ab !2F0671#A&7I7%,: !'')::"(JQv+);A)>&)HJ J ~ ! #""1% 3nRS6II)-n)= DIf~V&++=>BJKQK8S!%%R.8KKSZ  S]]_eTU V&13  /B 8:J9Ks<, J:7J:J?0KKK  KK.KKzscada_config.jsongF@gd@roT)lowest_overalllowest_sustainedhighest_sustainedhighest_overallroc1id max_deltawindow_minutesenablednotify) low_limit high_limitsustain_minutesr rate_rulesc hg}t}t|D]\}}t|ts t |j d}t |j d}|dks|dkrXt|j dxsdjxsd|dz}|d} }||vr|d | }| dz } ||vr|j||j|||t|j d d t|j d d d|S#ttf$rYwxYw)a:Validate/normalize a raw ``rate_rules`` list, dropping malformed entries. Each kept rule has a unique string ``id``, positive ``max_delta`` (F) and ``window_minutes`` (int), plus bool ``enabled``/``notify``. Bad rules are dropped rather than raising so a hand-edited config still builds a report. rrrrrrocr1r_rTrFr)set enumerate isinstancedictfloatrr5rHrGr~r@addrDbool) raw_rulesoutseenirrwindowridbasens r_normalize_rate_rulesrfs@ C 5D)$ 1!T"  aeeK01I/01F >Vq[ !%%+#$**,=#a!eW qaTkF!A3-C FATk   "$AEE)T23155512   ! . J#:&   s4DD10D1c*|bi}tjrL tjtj }t |j dtr|d}dttdi}dtfdtfdtffD](\}} ||j |t|||<*|j d}t |tr$tD]}||vst!|||d|<d|vr&t |dt"rt%|d|d<|StdDcgc] }t|c}|d<|S#tjtf$rYwxYw#ttf$rt|||<YwxYwcc}w)uReturn merged criteria settings: ``raw`` (or scada_config.json's ``report_criteria``) over SCADA_CRITERIA_DEFAULTS. Bad values fall back to the default rather than raising — the report must still build when the config file is hand-edited.report_criteriarrrrr)SCADA_CONFIG_PATHis_fileraloads read_textrrrJSONDecodeErrorOSErrorSCADA_CRITERIA_DEFAULTSrr5rHrG_CRITERIA_KEYSrrBr)rawsavedrrcastrrRrs rscada_report_criteriars  {  $ $ &  #4#>#>#@Aeii(9:DA 12C d29=> ?C"E*\5,A(#.04 T 4CGGC)@)EFGCH4 ggi G'4  5AG|$($4Iq! 5 sz#l*;TB1#l2CDL J/Fl.STT!WTL J)(('2  :& 4.s3CH 4Us*A E"E/5FE,+E,/F  F c i}|dD]}|d}t|Dcgc](\}}|dt|dz fvrd|vr |t|f*}}}|dD]}tj |dxsdj }|s0 d|j D\} } } } } }t| | | | | |}|D]7\}} t||}|j|gj||f9|jD]}|jd |Scc}}w#ttf$rYwxYw#tttf$rYwxYw) u Extract per-Temp-sensor time series from a built report. Returns {sensor: [(datetime, float), ...]} sorted by time. Non-numeric values ("x.x" gaps) are skipped; RH / Vin / Trigger columns are ignored — the criteria are temperature-compliance checks. rr<rr1Tempr=rc32K|]}t|ywr3r4r6s rr9z'_scada_sensor_series..s)EQ#a&)Er:c |dS)Nrr,)ps rrz&_scada_sensor_series..s qtrr)rrCr]rArr@rFrrGrHr IndexErrorrrDrPsort)reportseriesrrQrrMtemp_idxrSrOrTrUrVrWrXrYrsensorvalptss r_scada_sensor_seriesrsFf~@9~;DT?D41aCIM 22v{*1-.DDv; @C &&A "';';'=>A )E!((*)E&BBBb"b"b"5& @ 6A-C!!&"-44b#Y?  @ @ @&}}% ^$% M'D *   ":z:s)-D.D";D7"D43D47E E cRd}g}|D]\}}||r|r!||ddz jdz |kDrg}|j||f|dd|ddz jdz }| ||dkDsqt|d|d|D|dd|ddd}g}|S) u Longest consecutive stretch of ``points`` where predicate(value) holds. Returns {"minutes", "extreme", "start", "end"} for the longest run or None; ``extreme_fn`` (min/max) picks the run's reported extreme. A gap between samples longer than ``gap_break_minutes`` breaks the run — missing data must not silently count as a sustained excursion. Duration is last-sample minus first-sample, so a single out-of-range sample is 0 min (the 15-min sample interval bounds what "sustained" can resolve). Nrrrominutesr1c3&K|] \}}| ywr3r,)r7rvs rr9z_longest_run..s-@DAqa-@s)rextremestartend) total_secondsrDround) points predicate extreme_fngap_break_minutesbestrunrrrs r _longest_runrs D C C S>SWQZ6682=@QQ JJCy !2wqzCF1I-<<>CG|wi8#(!#4#--@C-@#@!$Q3r71:?C  Krc d}d}tt|D]}||\}}||krI|||dz jdz |kDr*|dz }||kr |||dz jdz |kDr*t||D]T}||\}} t|| z } | | |dkDs$t | d||| |t ||z jdz dd}V|S)urLargest absolute value change between any two readings that fall within a rolling ``window_minutes`` window (DVI-1148, change over time). Returns {"delta", "start", "end", "start_val", "end_val", "span_minutes"} for the worst change, or None when fewer than two readings share a window. Tracks absolute change (rise OR fall — both are thermal-integrity risks). Gap-aware: only pairs whose timestamps are within ``window_minutes`` of each other are compared, so a data gap wider than the window is never mistaken for an instantaneous jump. A trailing left pointer keeps this ~O(n · window). Nrror1deltar)rrr  start_valend_val span_minutes)rErCr absr ) r rrlohidt_hival_hirRdt_kval_krs r_max_rate_of_changers  D BCK r v2g56":a=0??ABFW !GB2g56":a=0??ABFWr2 A )KD%'E|utG}4"5!_!%!&6$)54<*F*F*H2*Mq$Q    Krcdt|t|d}|y|dt|dkD|fS)uyEvaluate one rate rule against a (datetime, value) series (DVI-1148). Shared by the report Summary and the live notification path. Returns ``(violated, info)`` where ``info`` is the :func:`_max_rate_of_change` result (or None when the window holds fewer than two readings, in which case ``violated`` is False — an unmeasurable window is never an alert). r)FNrr)rr5r)r rulers rscada_rate_rule_checkr"sA fc$/?*@&A BC { w<%[ 12 2C 77rc,|r|jdSdS)Nz%m/%d/%Y %H:%Mr)r)rs r_fmt_dtr$s,.2;;' (6B6rctt|tr|nd}|d|dc|d}|d}t|}g}d}t |D]Y}||} | D cgc]\} } |  } } } g} |j dr[t | tfd| D}k\}| jdd d d t||d d d t|d|j drt| fdt t|d}|duxs|d|k}| jddd d|d|r|dnd|r't|ddt|dd|dd dnd||rdd d|dd d|dd d nd!d d d|j d"rt| fd#tt|d}|duxs|d|k}| jd"d$d d|d|r|dnd|r't|ddt|dd|dd dnd||rd%d d|dd d&|dd d nd'd d d|j d(r[t| tfd)| D}k}| jd(d*d d t||d+d d t|d|j d,gD]}|j ds|d-|d.|d/}}}t| |}|)| jd0|d1|d d2|d|dddd3|d4d[|d5|k}| jd0|d1|d d2|d||d5t|ddt|dd|d6d d|d7|d5d d8|d9d d:|d;d d<|d6d d dtd=| D}|xr|}|j|| |d>\|||r|d?Sdd?Scc} } w)@aEvaluate the enabled report criteria against a built report. Returns {"settings", "sensors": [{sensor, checks: [...], pass}], "pass"}. Each check: {key, label, threshold, observed, when, pass, detail}. ``pass`` is None (informational) when a check has no data to judge. NrrrrTrc34K|]\}}|k(s |ywr3r,)r7rrvmins rr9z*_scada_criteria_summary..-9ur1qDy9 z(Lowest temp (entire period) at or above r8FzLowest reading zF at )rlabel thresholdobservedwhenpassdetailrc|kSr3r,)rlows rrz)_scada_criteria_summary..7s a#grrorz Never below zF for more than  minrru – r z (z min)rzLongest stretch below z F lasted z min (low zF)zNo readings below rc|kDSr3r,)rhighs rrz)_scada_criteria_summary..Fs a$hrz Never above zLongest stretch above z min (high zNo readings above rc34K|]\}}|k(s |ywr3r,)r7rrvmaxs rr9z*_scada_criteria_summary..Vr(r)z)Highest temp (entire period) at or below zHighest reading rrrrrate_of_change_zChange no more than z F within any zNot enough data within a z) min window to measure the rate of changerrzLargest change zF (rzF to rzF) over c3*K|] }|ddu yw)r/FNr,)r7rMs rr9z*_scada_criteria_summary..|sAQ!F)50As)rchecksr/)settingsrr/)rrrrrrrrrDr$rmaxrall)rcriteriacritsustainrr sensors_out overall_passrrrrvalsr:r.okrr!mdwmrr sensor_passr5r2r7r's @@@@r_scada_criteria_summaryrHs1 !Z$-GT RD[!4 #5IC$%G9oG !& )FKL.XVVn!"da"" ;;' (t9D999DB MM'CC7!L dGDM+D85H   ;;) *s$5sCwitL .1C Nt:=$CL12%E 8K7Lc)nQ/u6CE"4C7)!)nQ/z#i.9K2O);C7!'D   ;;* +s$6S"=MNC9I' 9B MM*'Qx/?yM!.1C Nt:=$CL12%E 8K7Lc)nQ/u6CE"4D89!)nQ/{3y>!:LBP);D81'E   ;;( )t9D999DB MM(DT!HAN!tWT],T!HE'$-I  HH\2. D88I&{+T2B-CT$ZCB%c2.C{ ,SE23Bq6rd$O!#r !:2$?< < W#B MM(./1v]2$dKS\#CL12%E 8K7LM 035:,S\!,<=";/2%Iq7I!.1!4D:  ! 8A&AA #3 f TUqXVt$/L ;;59 ;;q#s N:c ddlm}ddlm}|}|j |j |r|dr|j d}|d}|d }|jd g|dd |d _|d}|r|ddd|ddnd} |jd| g|jdd|ddd|ddd|ddg|d} |jd| rdn| d urd!nd"g|jd#d$%} |d| rd&nd'(| _|jggd)} |j| td*t| d*zD]} ||jd+| %_|dD]~}|d,D]t}|drdn |dd urd!nd-}|j|d.|d/|d0|d1||d2g|j|jd3%}||dd u|dd urd'nd&(|_vd4d5d6d7d8d9d:}|jD]\}}||j|_|ds|j d;|dD]}t!j"dd?}|j |}|jd@|dg|jg|j|dA|dBD]}|j|t%j&}|j)||j+d|S)CzBuild an XLSX workbook from a report dict: an optional criteria Summary sheet first, then one sheet per day (title row, blank row, column header row, data rows).r)Workbook)FontrSummary)titleT)boldr;u,Kiln Temperature Report — Criteria Summary)rNsizeA1rrz to rzno dataPeriodLimitszLow rr8z F / High rzF / Sustained window rr3r/zOverall resultPASSFFAILNO DATAr)rScolumnFF008000FFCC0000)rNcolor)Sensor CriterionObservedWhenResultDetailr1r:zN/Arr+r-r.r0 , $8)ABCDEr*zNo Dataz [:\\/?*\[\]]-Nz X-400 - Logr<r=)openpyxlrJopenpyxl.stylesrKremoveactive create_sheetrDfontcellrErCmax_rowitemscolumn_dimensionswidthr!r$ioBytesIOsaveseek)rcriteria_summaryrJrKwbwsrNrrroverallrwheaderrMrchkresultrcwidthsrwrrMrSbufs r_scada_report_workbookrso"$ BIIbii,Y7 __9_ - Z ( ABC$R04 f~?CDGFO$Db&)9(:; 8V$% 8!K.+9Q|_Q4GH''():';& i(f~S[9#2> __5_ ) =#f+./ "  #i.!v; C IIcN  **,CGGCLHHQK Jrr1c |jdgDcgc]W}|jdt|jdg|jdgDcgc] }t|c}dY}}}d}|rD|jdr3|jd|jd |jdd }t|jdg|jd d t|jd g|jdt||r|d dnd|r|ddndd}|r|j|t|||dScc}wcc}}w)u$Normalize a built report + criteria summary into the viewer view-model. Returns ``{version, meta, summary, days:[{date, columns, rows}]}``. ``summary`` is the criteria pass/fail block (``{pass, settings, sensors}``) or None when the report type declares no criteria. ``meta`` merges derived facts (period, row count, sensors) with any caller-supplied metadata (schedule name, source, generated-at). All values are JSON-serializable — the criteria summary uses pre-formatted ``when`` strings, so no datetime leaks in. rrr<r=rNrr/r;)r/r;rrrrrr)r<rrr day_countrr)versionmetasummaryr)rrBrCupdateVIEW_MODEL_VERSION)rrrdrrrvm_metas rbuild_report_view_modelrsUZZ+ -UU6]QUU9b12'(uuVR'89!d1g9 ; -D -G,00;$((0(,,Z8'++I6   9b12ZZ Q/!&**-@""EFO4Y(,T!WV_$'+48F#G t%  ): -sAEE+EEc6t|jdS)zASibling ``.json`` path for a generated ``.xlsx``.z.json)r with_suffix) xlsx_paths rview_model_path_forrs  ? & &w //rct|}t|||}|jtj|d|S)zPersist the sibling ``.json`` view-model beside a generated XLSX. Returns the JSON path. Raises OSError on write failure so the caller can decide whether that should degrade the (already-persisted) report/email. r)indent)rr write_textradumps)rrrr json_pathvms rwrite_report_view_modelrs< $I.I )94 @B Bq12 r exceptions)include_viewer_linkinclude_summaryinclude_out_of_specinclude_rate_violations summary_modec|bi}tjrL tjtj }t |j dtr|d}tt}t |tr7dD]}||vst||||<|j d}|dvr||d<|S#tjtf$rYswxYw)uMerged report-email settings: ``raw`` (or scada_config.json's ``report_email``) over REPORT_EMAIL_DEFAULTS. Bad/absent values fall back to the default rather than raising — the email must still send when the config is missing or hand-edited. report_email)rrrrr)rfull) rrrarrrrrrrREPORT_EMAIL_DEFAULTSr)rrrrmodes rreport_email_settingsrs {  $ $ &  #4#>#>#@Aeii7>/C $ %C#tF *CczC>C *ww~& ) )"&C  J(('2  sA B==CCcxt|jddjddjddS)N&z&z>)r~r)rss r _email_escr8s1 J WS' "773#7V8LNrc B|xs t}|jdsy|r|jdsy|jdddk7}|jdd}|jd d}g}|dD]}|jd gD]}t|jd djd } | r|s2| s|s7|jd du} |r| sO|j |jdd| |jd|jdd| f|jd } | durd\} } }n| durd\} } }nd\} } }dj | dj || | g}|rwg}|D]I\}} }} | rdnd}| rdnd}|j dj t |||t |K|j ddj|zd zn|j d!|j d"dj|S)#uCompact HTML "Attention" block for a report email body (DVI-1165). Renders the overall PASS/FAIL result plus, per the toggles in ``opts``, the out-of-spec sensor checks (over-high / under-low overall+sustained) and the change-over-time (rate-rule) violations. ``summary_mode`` "exceptions" (default) shows only *failing* checks; "full" shows every enabled check. Returns "" when there is nothing to render — the summary is disabled, the report type has no criteria, or (exceptions-only) every criterion passed and there are no rows to show. Callers append the returned fragment into the email body; an empty string simply adds nothing. rrrrrrrTrr:rr8r/Frr0r+)rU#b91c1cz#fef2f2)rT#166534z#f0fdf4)rVz#4b5563z#f9fafbzW
)rMz
Attention · {st}
)bgrMstzRate of changez Out of specrrac{s}{tag}{d})rdottagrzjz
zk
All monitored criteria are within limits.
z
)rrr~ startswithrDformatrrz)rroptsexceptions_only show_spec show_rater=rris_ratefailedr status_txtr[rpartstrsr0rrs rbuild_report_email_summaryr=sk  *(*D 88% & #3#7#7 #Bhh~|<FO.5I2D9I D"9- K::h+ KC#''%,-889JKGy9WWV_-Fv KKHb173777B+?@&J K K K""6*G% < E2 D < E2 ? E2 #VeV_ /06vu:D060F  E /3 + +FGVV&-"=C%)9C JJ0 17 (cs (171* + +   >ggcl ' ( )   > ? LL 775>rc^eZdZdZdddddddddZedZdd Zdd Zdd Z dd Z d Z y) ReportTypea!Descriptor bundling a report's data source, criteria, and XLSX layout. ``build(date_from, date_to, sensors) -> report dict`` and ``workbook(report, criteria_summary) -> BytesIO`` are required. Criteria are optional: a type with ``has_criteria`` supplies ``criteria`` (a validator ``raw -> merged dict``) and ``criteria_summary`` (``(report, raw) -> summary``); ``criteria_config_key`` names where its settings live in scada_config.json and ``criteria_keys`` lists its per-check enable-flag keys (for the editor UI). rrNr,)r descriptionr>criteria_defaultsr criteria_keyscriteria_config_keyc ||_||_||_||_||_||_||_| |_|xsi|_t| |_ | |_ yr3) rr\rr_build _workbook _criteria_criteria_summaryrtuplerr) selftype_idr\buildworkbookrrr>rrrrs r__init__zReportType.__init__s`  & !!!1!2!8b"=1#6 rc>|jduxr|jduSr3)rrrs r has_criteriazReportType.has_criterias!~~T)Pd.D.DD.PPrc(|j|||Sr3)r)rrrrs rrzReportType.builds{{9gw77rc@|jr|j|SdS)zAMerged criteria settings for this type, or None when it has none.N)r)rrs rr>zReportType.criterias&*nnt~~c">$>rcB|jr|j||SdS)zEvaluated pass/fail summary for this type, or None when it has none. ``raw`` is the persisted criteria block (or None to read the shared config file); the summary function re-merges it through the validator. N)rr)rrrs rrzReportType.criteria_summarys$ 7;6G6Gt%%fc2QTQrc&|j||Sr3)r)rrrs rrzReportType.workbooks~~f&677rc|j|j|j|j|jt |j |jdS)z;JSON-serializable descriptor for the report-type picker UI.)rr\rrrrr)rr\rrrrBrrrs rinfozReportType.infosL''IIZZ++ --!$"4"45#'#;#;  rNNNr3) __name__ __module__ __qualname____doc__rpropertyrrr>rrrr,rrrrsRAB$$"&b%)7 QQ8?R8  rr kiln_tempc,|t|j<|Sr3) _REPORT_TYPESr) report_types rregister_report_typers$/M+..! rcB|r|tvr t|SttS)uResolve a report type by id, falling back to the default (kiln_temp). An unknown or empty id resolves to the default, so schedules created before the registry (which carry no ``report_type``) stay on the Kiln Temp engine — the source of the byte-identical guarantee. )rDEFAULT_REPORT_TYPE_ID)rs rget_report_typers%7m+W%% / 00rcBttjdS)z=All registered types, ordered for display (order, then name).c2|j|jfSr3)rr\)ts rrz#list_report_types..s!&&8Irr)rrrPr,rrlist_report_typesrs -&&(.I JJrzKiln Temp ReportzLDaily X-400 kiln temperature logs with low/high/sustained compliance checks.r) rrrrr>rrrr)NNidescirr3)NN)Arrr|raosr!rrpathlibr urllib.parserrtrequestsr{environrrvrx _AZ_TENANTrwr compilerAr#rrrr)r.rZr]rerrr__file__resolveparentrrrrrrrrr"r$rHrrrrrrrrrrrrrrrr,rrrsC. ( !  0"5 ZZ^^12 6 ZZ^^-r 2 9*F 0HI 2::YZ'BJJ'CRTTJ" #;RTTB ( .%.P9 "=AHL.b.KlN**,336II ! DBD *!,: F F@6< 87j;Z;P%P0 0 # 8N N@; ; | $ 1K Z# &  # "-, )  r