j %SrSSKJr SSKrSSKJr SSKJrJr SSK r \"\ RRS\ "\"\5RS- 555rSNSjrSOS jrSPS jrSQS jrSRS jrSSS jrSSSjrSTSjrSTSjrSQSjrSTSjrSUSVSjjrSSSjrSSSjrSSKr SSK!J"r# \ RH"S5r%\ RH"S5r&Sr'Sr(SWSjr)SXSYSjjr*SZS[Sjjr+Sr,S\S jr-S]S^S!jjr.S_S"jr/S#r0S`S$jr1SUSaS%jjr2SSK3r4SS&K!J!r5J6r7 SSK8r9S'r:S(r<\ RH"S)5r=SbS*jr>ScS+jr?SdS,jr@SeS-jrAS.S/S.S'S0.S.S1S2SS0.S/S2S3SS0.S2S4S5SS0.S6S6S6SS0.S7.rBS8\CS9'SfS:jrDSgS;jrEShS<jrFSiS=jrGSjS>jrHSkS?jrISlS@jrJSUSmSAjjrKSnSBjrLSoSCjrMSpSDjrNSqSEjrO\P"1SFk5rQSGrRSrSHjrSSsSIjrTS\SJjrUStSuSKjjrVSvSLjrWSwSMjrXg!\;a Sr9Sr:GNf=f)xu ERGON - Funciones de query para la API de obras. Cada funcion recibe una conexion SQLite y devuelve un dict o lista lista para serializar a JSON. No hace networking ni maneja HTTP — es logica pura. Convenciones: - Codigos de obra llegan desde la URL (ej: "TDG1"). - Si la obra no existe, las funciones devuelven None o [] segun corresponda. - Datos demo se etiquetan en el payload con "es_demo": true. ) annotationsN)Path)AnyOptional DATABASE_PATHzergon.dbc[R"[[55n[RUlUR S5 U$)NzPRAGMA foreign_keys = ON)sqlite3connectstrDB_PATHRow row_factoryexecute)conns /app/db/api_obras.pyget_connrs2 ??3w< (D{{DLL+, KcRUR5Vs0sHoX_M sn$s snfN)keys)rowks r _row_to_dictrs$"xxz *z!svIz ** *s$cURS5R5nUVs/sHn[U5PM sn$s snf)z4Lista compacta de obras para el selector del header.z SELECT id, codigo, nombre, cliente, moneda, es_demo, fecha_inicio, fecha_fin_plan, fecha_corte_actual, dg_nivel_servicio FROM obras ORDER BY es_demo ASC, codigo )rfetchallr)rrowsrs r list_obrasr's? <<   &* *TLOT ** *s<clURSU45R5nU(a [U5$S$)z(Detalle completo de una obra por codigo.z2 SELECT * FROM obras WHERE codigo = ? N)rfetchonerrcodigors rget_obrar#3s8 ,,  HJ!$< --rc`URSU45R5nU(aUS$S$)Nz%SELECT id FROM obras WHERE codigo = ?id)rr r!s r_obra_idr&;s/ ,,> J S S UC3t9%%rc[X5nUc/$URSU45R5nUVs/sHn[U5PM sn$s snf)Nzv SELECT orden, nombre, peso_pct FROM rubros_obra WHERE obra_id = ? ORDER BY orden r&rrrrr"oidrrs r get_rubrosr+DsZ 4 C { <<      &* *TLOT ** *Ac[X5nUc/$URSU45R5nUVs/sHn[U5PM sn$s snf)Nz SELECT s.orden, s.nombre, s.contacto, r.nombre AS rubro FROM subcontratistas s LEFT JOIN rubros_obra r ON r.id = s.rubro_id WHERE s.obra_id = ? ORDER BY s.orden r(r)s rget_subcontratistasr.QsZ 4 C { <<      &* *TLOT ** *r,c B[X5nUc//SS.$URSU45R5nURSU45R5Vs/sHoDSPM nn/nUH`nURSX'S45R5nURUSUSUS UV s/sHn [ U 5PM sn S .5 Mb URS U45R5n UUU Vs/sHn[ U5PM snS .$s snfs sn fs snf) N)rubrosmesesagregadoj SELECT id, orden, nombre, peso_pct FROM rubros_obra WHERE obra_id = ? ORDER BY orden z\ SELECT DISTINCT mes FROM avance_mensual WHERE obra_id = ? ORDER BY mes mesz SELECT mes, plan_acum_pct, real_acum_pct FROM avance_mensual WHERE obra_id = ? AND rubro_id = ? ORDER BY mes r%ordennombrepeso_pctr5r6r7seriea SELECT a.mes, ROUND(SUM(a.plan_acum_pct * r.peso_pct / 100.0), 2) AS plan_global, ROUND(SUM(CASE WHEN a.real_acum_pct IS NOT NULL THEN a.real_acum_pct * r.peso_pct / 100.0 ELSE 0 END), 2) AS real_global FROM avance_mensual a JOIN rubros_obra r ON r.id = a.rubro_id WHERE a.obra_id = ? GROUP BY a.mes ORDER BY a.mes )r1r0r2r&rrappendr) rr"r*r0rr1 rubros_outrubr9saggs r get_avancer@cse 4 C {rt<< \\  $||-     !uX E  J  t9   (xz  \(mJ/45u!l1ou5    ,,   .12c\!_c2 G "6*3sD/D8Dc [X5nUc/SS.$URSU45R5n/nUH`nURSX%S45R5nURUSUSUSUVs/sHn[ U5PM snS.5 Mb URS U45R5nXHV s/sHn [ U 5PM sn S.$s snfs sn f) N)r0r2r3z SELECT mes, plan, real FROM presupuesto_mensual WHERE obra_id = ? AND rubro_id = ? ORDER BY mes r%r5r6r7r8a  SELECT mes, ROUND(SUM(plan), 0) AS plan_mes, ROUND(SUM(CASE WHEN real IS NOT NULL THEN real ELSE NULL END), 0) AS real_mes FROM presupuesto_mensual WHERE obra_id = ? GROUP BY mes ORDER BY mes r:) rr"r*r0outr=r9r>r?rs rget_presupuestorCs 4 C {$// \\  C  t9   (xz  \(mJ/45u!l1ou5    ,,  'EA Q'E FF6(Fs ;CC!c[X5nU(dgUSSSn[US5nURSX45R5nU(aUScg[US5n[US=(d S5nXF-S - nXG-S - n URS X45R5n [U S =(d S5n X- n X- n US:a[ X- S 5OSnU S:a[ X- S 5OSnU(a[ XO- S5OSnURS U45R5SnUS::aSnOUS:aSnO SUS- S-- nU(a[ USUS - - -S5OSnU(a[ USUS - --S5OSnUU[ US5[ US5[ U S5[ U S5[ U S5[ U S5UUUU[ US5UUSUSUSS3S.S. $)aCalculo EVM al `fecha_corte_actual` de la obra. Sigue la formula del CURVA_S del FCAT1: BAC = presupuesto_total PV (t) = BAC * plan_acum_pct_global(t) / 100 EV (t) = BAC * real_acum_pct_global(t) / 100 AC (t) = sum(real de presupuesto_mensual hasta t) SV = EV - PV, CV = EV - AC SPI = EV / PV, CPI = EV / AC EAC (CPI) = BAC / CPI Devuelve None si la obra no existe o no hay data suficiente. Nfecha_corte_actualpresupuesto_totala SELECT ROUND(SUM(a.plan_acum_pct * r.peso_pct / 100.0), 4) AS plan_global, ROUND(SUM(CASE WHEN a.real_acum_pct IS NOT NULL THEN a.real_acum_pct * r.peso_pct / 100.0 ELSE 0 END), 4) AS real_global FROM avance_mensual a JOIN rubros_obra r ON r.id = a.rubro_id WHERE a.obra_id = (SELECT id FROM obras WHERE codigo = ?) AND a.mes = ? plan_global real_globalrY@z SELECT ROUND(SUM(real), 0) AS ac FROM presupuesto_mensual WHERE obra_id = (SELECT id FROM obras WHERE codigo = ?) AND mes <= ? AND real IS NOT NULL acz SELECT COUNT(DISTINCT mes) AS n FROM avance_mensual WHERE obra_id = (SELECT id FROM obras WHERE codigo = ?) AND real_acum_pct IS NOT NULL ng.@g@g?z=Intervalo se estrecha a medida que la obra genera datos. Con z$ mes(es) de data real, banda de +/- z.1fz%.)meses_con_data banda_pcteac_loeac_hinota) r" corte_mesbacpvevrKsvcvspicpieac calibracion)r#floatrr round)rr"obrarUrVrrHrIrWrXac_rowrKrYrZr[r\r]meses_con_realrQrRrSs rget_evmrdsX D !D )*2A.I () *C ,,    'hj #m$,M*+KM*/a0K U "B U "B \\    'hj   vd| q !B B B!Av% 4C!Av% 4C!$% 1 $C\\#   HJs $N 2  NQ.;?? 8;U3!i%//0! 4F8;U3!i%//0! 4FS!}BlBlBlBlBl,y!,*++OPYZ]^`b   rcLSSKnURX5nURS/5HxnUSUS'URS5=(d 0nSU;aURSUS5 SU;aURSUS5 S U;dMcURS US 5 Mz U$) aRF11 (2026-04-20): delega a `alertas_engine.evaluar()`. Motor de reglas con 8 reglas (R1-R8): avance/sobrecosto por rubro, fecha fin proyectada (EAC_date via SPI), contratos vencidos y sin firma. Retrocompat: cada alerta incluye `estado` como alias de `severidad` para no romper frontends pre-F11. El alias se puede retirar en sprint 4. rNalertas severidadestadocontexto desvio_pp plan_acum_pct real_acum_pct)alertas_engineevaluarget setdefault)rr"rmpayloadactxs r get_alertasrt)s$$T2G[[B ' n( eeJ%2 #  LLc+&6 7 c ! LL#o*> ? c ! LL#o*> ?( Nrc[X5nUc/SS.$SnU/nU(aUS- nURU5 U(aUS- nURU5 US- nURXV5R5nURSU45R 5nUV s/sHn [ U 5PM sn U(a [ U5S.$SS.$s sn f)N)diasresumenzoSELECT fecha, total_personal, lluvia_mm, dia_perdido, notas FROM asistencia_diaria WHERE obra_id = ? AND fecha >= ? AND fecha <= ?z ORDER BY fechaa SELECT ROUND(AVG(total_personal), 1) AS promedio, SUM(dia_perdido) AS dias_perdidos, ROUND(SUM(lluvia_mm), 1) AS lluvia_total_mm, COUNT(*) AS n_dias FROM asistencia_diaria WHERE obra_id = ? )r&r;rrr r) rr"desdehastar*qargsr resumen_rowrs rget_asistenciarFs 4 C {t,, 7AeD   E   E A << ) ) +D,,     +//$Qa$/0;< , AE /sC c[X5nUc/$URSU45R5nUVs/sHn[U5PM sn$s snf)NaC SELECT c.tipo, c.descripcion, c.fecha_emision, c.fecha_firma, c.fecha_vence, c.estado, c.monto, s.nombre AS subcontratista FROM contratos c LEFT JOIN subcontratistas s ON s.id = c.contratista_id WHERE c.obra_id = ? ORDER BY c.fecha_emision, c.tipo r(r)s r get_contratosrgsZ 4 C { <<   &* *TLOT ** *r,c[X5nUc/$URSU45R5nUVs/sHn[U5PM sn$s snf)Nz SELECT item, unidad, recibido, consumido, ROUND(recibido - consumido, 2) AS saldo, ultima_update FROM materiales WHERE obra_id = ? ORDER BY item r(r)s rget_materialesrwsZ 4 C { <<   &* *TLOT ** *r,)datez^[A-Z0-9]{3,6}$z^\d{4}-\d{2}-\d{2}$) r"r6clienterG fecha_iniciofecha_fin_planrEumbral_desvio_pctumbral_critico_pctdg_nivel_servicio) ubicaciontipomonedadg_fiscalizadordg_responsabledg_version_templatees_democ[U[5(a[RU5(dgUR S5upn[ [ U5[ U5[ U55$![[4a gf=f)N-) isinstancer _FECHA_REmatchsplit_dateint ValueError TypeError)r>ymds r _parse_datersh a  Y__Q%7%7''#,aSVSVSV,,  "s;A..BBFcH /n[U[5(dS/$[H.nURU5S;dMUR SU35 M0 URS5n[U[ 5(a/[ RU5(dUR SUS35 [URSS55nUS::aUR S 5 [URS S 55n[URS S 55n[URSS 55nURS 5(aU(dUR S5 URS 5(aU(dUR S5 URS5(aU(dUR S5 U(aU(aXv::aUR S5 U(aU(aX:aUR S5 [URSS55n [URSS55n U S:dU S:aUR S5 X::aUR S5 [URSS55n U S;aUR S5 URS/5n [U [5(a[U 5S:XaUR S5 GOTSn [5n[!U 5GH unn[U[5(dUR SUS -S!35 M6URS"5=(d S R#5nU(dUR SUS -S#35 MUR%5U;aUR S$US%35 UR'UR%55 [URS&S55nUS:dUS':aUR S(US)35 U U- n GM [)U S+- 5S,:aUR S-U S.S/U S'- S0S135 URS2/5n[U[5(dUR S35 U$[!U5H|unn[U[5(dUR S4US -S!35 M5URS"5=(d S R#5(aMdUR S4US -S#35 M~ U$![[4a UR S 5 GNHf=f![[4a UR S5 GNf=f![[4a UR S5 GNf=f![[4a UR S(US*35 GMf=f)5zoValida el payload antes de tocar la DB. Devuelve lista de errores (strings). Lista vacia = valido. No hace IO. zPayload debe ser un objeto JSON)NzCampo requerido ausente: r"zcodigo invalido 'zL'. Formato esperado: 3 a 6 caracteres A-Z o 0-9, sin espacios ni minusculas.rGrz'presupuesto_total debe ser mayor que 0.z$presupuesto_total debe ser numerico.rrrrEz!fecha_inicio debe ser YYYY-MM-DD.z#fecha_fin_plan debe ser YYYY-MM-DD.z'fecha_corte_actual debe ser YYYY-MM-DD.z1fecha_fin_plan debe ser posterior a fecha_inicio.z8fecha_corte_actual no puede ser anterior a fecha_inicio.rrzumbrales deben ser >= 0.z8umbral_critico_pct debe ser mayor que umbral_desvio_pct.zumbrales deben ser numericos.r)rNz$dg_nivel_servicio debe ser 1, 2 o 3.r0zDebe incluir al menos un rubro.gzRubro #rNz: formato invalido.r6z: nombre vacio.zRubro duplicado: 'z'.r7dzRubro 'z': peso fuera de rango (0-100).z': peso no numerico.rJg{Gz?zSuma de pesos de rubros = z.2fu0%. Debe ser 100% (± 0.01%). Diferencia actual: z+.2fzpp.subcontratistasz#subcontratistas debe ser una lista.zSubcontratista #)rdict_OBRA_REQUIRED_FIELDSror;r _CODIGO_RErr_rrrrlistlenset enumeratestriploweraddabs)rq is_updateerrorsfieldr"presuf_inif_finf_coru_desu_crinivelr0 suma_pesosnombres_vistosirr6pesosubsr>s rvalidate_obra_payloadrsF gt $ $122' ;;u  + MM5eW= >' [[ "F&#z'7'7'?'? x's t >gkk"5q9: A: MMC D  NB7 8E  $4b9 :E  $8"= >E{{>""5 9:{{#$$U ;<{{'(( ?@ 5> IJ 5= PQ7gkk"5q9:gkk"6:; 19 MM4 5 > MMT U >GKK 3Q78  ! MM@ A [[2 &F fd # #s6{a'7 78 #&5f%DAqa&& !u,?@AeeHo+224F !uO<=||~/ 26("=>   v||~ . FQUU:q12!8tczMMGF83R"STd" &$ zE! "T ) MM,Z,<=&&03&6t% <=>4 z "7 567 z "> <=>4z* F x/CDEE FsJ)2S??A)T')2UAU7?!T$#T$'!U  U !U43U47%V! V!c [U[U5S9nU(aSUSS.$URS5=(d SR5R 5nU(a*UR 5n[ X5nUc SSUS 3/S S.$O[ X5b SS US 3/S S.$URS5=(d SR5=(d SnURS5=(d SR5=(d SnURS5S;aSOSnUR 5n U RS5 U(Ga>U RSURS5URS5URS5URS5U[URS55URS5URS5URS5[URS 55[URS!55[URS"55URS#5URS$5XxU45 [ X5n U RS%U 45 U RS&U 45 Sn GOU RS'XARS5URS5URS5URS5U[URS55URS5URS5URS5[URS 55[URS!55[URS"55URS#5URS$5Xx45 U Rn S(n 0n [URS)/5SS*9HupURS5=(d SR5n[URS+S55n[URS,U 55nU RS-U UUU45 U RXR5'M [URS./5SS*9Hun nURS5=(d SR5nURS/5=(d SR5R5nU RU5n[URS,U 55nU RS0U UUUURS15URS2545 M UR5 S(XJU S3.$![RaZnUR!5 [#U5nS4UR 5;aU(aSS5US63/S S.sSnA$SS7U3/SS.sSnA$SnAf[$a$nUR!5 SS8U3/S9S.sSnA$SnAff=f):uCrea o actualiza una obra con sus rubros y subcontratistas. Si `codigo_existente` es None, INSERT. Si se provee, UPDATE (payload.codigo debe coincidir — si difiere, se usa el del path). Transaccional: rollback atomico si cualquier paso falla. Devuelve: {"ok": True, "codigo": "...", "obra_id": N, "created": bool} o: {"ok": False, "errors": [...], "status": 400|404|409|500} )rFokrstatusr"rNzObra  no encontradazYa existe una obra con codigo z. Use editar en lugar de crear.rPYGrzv1.0r)rNT1rNrBEGINa  UPDATE obras SET nombre = ?, cliente = ?, ubicacion = ?, tipo = ?, moneda = ?, presupuesto_total = ?, fecha_inicio = ?, fecha_fin_plan = ?, fecha_corte_actual = ?, umbral_desvio_pct = ?, umbral_critico_pct = ?, dg_nivel_servicio = ?, dg_fiscalizador = ?, dg_responsable = ?, dg_version_template = ?, es_demo = ?, updated_at = datetime('now') WHERE codigo = ? r6rrrrGrrrErrrrrz-DELETE FROM subcontratistas WHERE obra_id = ?z)DELETE FROM rubros_obra WHERE obra_id = ?a INSERT INTO obras ( codigo, nombre, cliente, ubicacion, tipo, moneda, presupuesto_total, fecha_inicio, fecha_fin_plan, fecha_corte_actual, umbral_desvio_pct, umbral_critico_pct, dg_nivel_servicio, dg_fiscalizador, dg_responsable, dg_version_template, es_demo ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) Tr0)startr7r5z| INSERT INTO rubros_obra (obra_id, orden, nombre, peso_pct) VALUES (?, ?, ?, ?) rrubroz INSERT INTO subcontratistas (obra_id, orden, nombre, rubro_id, contacto, notas) VALUES (?, ?, ?, ?, ?, ?) contactonotas)rr"obra_idcreatedz FOREIGN KEYzENo se puede reemplazar la lista de rubros o subcontratistas: la obra z ya tiene avance, presupuesto o contratos registrados que los referencian. Edite los datos escalares (fechas, presupuesto, umbrales) sin cambiar la lista de rubros, o solicite un merge asistido.zRestriccion de base de datos: zError interno: )rboolrorupperr&cursorrr_r lastrowidrrcommitr IntegrityErrorrollbackr Exception)rrqcodigo_existenterr"existingrversionrcurrrrubro_id_by_nombreidxrr6rr5r> rubro_refrubro_idemsgs r upsert_obrarsH#7d;K6L MF v==kk(#)r 0 0 2 8 8 :F!'')D)  eF8>,J+KWZ[ [  D ! -;F8Cbcd kk(#,u 3 3 5 >F{{01;VBBDNG;;y)^;aG ++-CpO G  KK  H%w{{9'= K('++f*=vgkk"567 N+W[[9I-J 01gkk"567gkk"678GKK 345 -. I)--i8Hgs+,E KKj!155>  M fWUU  ! !  !f CIIK ',<['()^^   7u=>  O /!(='>#NNOs>+PUW!AV0W!! V0*W!0 W!=WW!W!)r%rfechasectorpisorT blob_path exif_gps_lat exif_gps_lon exif_fechausuario mime_type size_bytes created_atc[X5nUc SSUS3/SS.$URS5=(d SR5nU(dSS /S S.$[R U5(d SS US 3/S S.$UR S UUURS5=(d SURS5=(d SURS5=(d SUURS5URS5URS5=(d SURS5=(d SURS5=(d S[ URS5=(d S54 5nUR5 [XUR5nSUSS.$![Ra$nUR5 SSU3/S S.sSnA$SnAff=f)zQInserta una fila en fotos_obra. Devuelve {ok, foto, status} o {ok:False, errors}.NFobra rrrrr!fecha es obligatoria (YYYY-MM-DD)rfecha invalida ''. Formato YYYY-MM-DD.a  INSERT INTO fotos_obra (obra_id, fecha, sector, piso, nota, blob_path, exif_gps_lat, exif_gps_lon, exif_fecha, usuario, mime_type, size_bytes) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) rrrTrrrrrz image/jpegrrT)rfotor Error DB: ) r&rorrrrrrget_fotorr rr) rr"metarrrrrrs r create_fotorst$G%x~(F'GSVWW XXg  $" + + -E (K'LX[\\ ??5 ! !)%0FGH  Jll (#+t&!)T&!)T((,'/4)$,+&6,DHH\*/a0  . cmm4DC88  ! !J *QC(8'9SIIJs6DFG#G<GGc[X5nUc/$SSR[5-S-nU/nU(aUS- nURU5 U(aUS- nURU5 U(aUS- nURU5 US- nUR Xg5R 5nUV s/sHn [ U 5PM sn $s sn f)zOLista fotos de una obra con filtros opcionales. Ordena por fecha desc, id desc.SELECT , z" FROM fotos_obra WHERE obra_id = ?rxryz AND sector = ? ORDER BY fecha DESC, id DESC)r&join _FOTO_FIELDSr;rrr) rr"rzr{rrsqlparamsrrs r list_fotosrst$G  DIIl++/ ! F     e     e     f **C << $ - - /D%) *TLOT ** *s.Cc[X5nUcgURSSR[5-S-X#45R 5nU(a [ U5$S$)z>@M }\]  Jll  W%-#t%W%--.6$      -0 03Q Q ]]   (* \%%8CHH  ! !J *QC(8'9SIIJsCF11G)G$G)$G)c\[X5nUc/$SSR[5-S-nU/nU(aUS- nURU5 U(aUS- nURU5 US- nUR XV5R 5nUVs/sHn[ U5PM sn$s snf)zALista entradas daily_log de una obra. Ordena fecha desc, id desc.rrz! FROM daily_log WHERE obra_id = ?rxryr)r&rrr;rrr) rr"rzr{rrrrrs rlist_daily_logr_st$G  DIIm,,0 ! F     e     e **C << $ - - /D%) *TLOT ** *sB))datetime timedeltaTrFz^[^@\s]+@[^@\s]+\.[^@\s]+$c[$r) _BCRYPT_OKrrbcrypt_availablers rc[(d [S5e[R"UR S5[R "55R S5$)zEDevuelve hash bcrypt como string utf-8. Lanza si bcrypt no instalado.z0bcrypt no instalado. Ejecute: pip install bcryptutf-8)r RuntimeError_bcrypthashpwencodegensaltdecode)plains r hash_passwordr$s? :MNN >>%,,w/1B C J J7 SSrc[(aU(dg[R"URS5URS55$![[ 4a gf=f)zIComparacion constant-time via bcrypt. False si bcrypt no esta disponible.Fr)rrcheckpwr rr)r#hasheds rverify_passwordr(sK :Vu||G4fmmG6LMM  "s4A AAcJUSUSUSUS[US5USUSS.n[UR55nS U;aUS US 'S U;aUS US 'S U;aUS US 'S U;aUS US 'S U;aUS US 'U$![a [5nN^f=f)z)Nunca incluir password_hash en la salida.r%emailr6rolactivor last_login_at)r%r*r6r+r,rr- plan_tiertrial_started_at trial_ends_atsubscription_statusempresa)rrrr)rbasers r_usuario_row_to_dictr4s$iWh-5zs8}%,'_- D388:d ,[T!#&'9#:  $ #O 4_$&)*?&@ "#Di.Y K usB B"!B"rNr) max_obras max_usuarios storage_gb watermark ri')trialn1n2n3 enterprisezdict[str, dict] TIER_LIMITSc FSSKJnJn URS5=(d SR5nURS5=(d SR5n[RU[S5nUS:HnSnSnSn U(aURS5n U (aUR U R S S 55n U RcU R URS 9n URUR5n X- n U R5nUS:aS n[S[US -55n O S nSn OS nSn US;a SnU(aS n[URS5=(d U5nUUUUUU U[!U5S.$![[4a S nSn N^f=f)a2Calcula el estado de prueba/suscripcion del usuario. Retorna dict con: plan_tier: tier vigente subscription_status: trial | active | expired | cancelled is_trial: True si plan_tier == 'trial' trial_active: True si trial y dentro de los 14 dias trial_expired: True si trial y vencido days_remaining: enteros >= 0 si trial activo, 0 si expirado, None si no trial watermark_required: True si exports deben llevar marca DEMO limits: dict con max_obras / max_usuarios / storage_gb r)rtimezoner.r=r1FNr0 T)tzinfoTiQ)expired cancelledr8)r.r1is_trial trial_active trial_expireddays_remainingwatermark_requiredlimits)rrDrorrB fromisoformatreplacerGutcnow total_secondsmaxrrrrr)rrrDr. sub_statusrPrKrLrMrN ends_at_strends_dtrTdeltasecsrOs rget_trial_statusr\s,[)4W;;=I++34?FFHJ __Y G(< =FG#HLM$(Nkk/2  $"001D1DS#1NO>>)%ooX\\oBGll8<<0 **,!8#'L%(C ,>%?N$(M%&N LN--  Mfjj5FG)$&(0v,  # * $# !# $s!BF 8F F F cV[U5nUS(agUSSnURS5nU(dgURS5S:Xag URS [U545R 5nU(aUS OS nXc:aS S USR 5SUSUS34$g )zVerifica si el usuario puede crear una obra mas segun su tier. Retorna (allowed, reason). reason es string vacio si allowed=True. rM)FzNTu prueba de 14 dias vencio. Activa una suscripcion para seguir creando obras.rPr5r%)FzUsuario invalido.r+admin)Trz=SELECT COUNT(*) AS c FROM usuarios_obras WHERE usuario_id = ?rFzTu plan r.z permite hasta z obra(s). Ya tenes z.. Actualiza a un plan superior para sumar mas.)r\rorrr r)rrrlimit usuario_id count_rowcounts rcan_create_obrarcs g &F of 8 [ )ET"J ){{5W$ G Zhj&IaL1E ~vk*0023?5'JwL N   rc[U[5(a[RU5(dgUR SUR 545R 5$)zHDevuelve la Row cruda (incluye password_hash para uso interno de login).Nz5SELECT * FROM usuarios WHERE email = ? AND activo = 1)rr _EMAIL_RErrrr )rr*s rget_usuario_by_emailrf-sI eS ! !)?)? <<?  hjrc~URS[U545R5nU(a [U5$S$)Nz#SELECT * FROM usuarios WHERE id = ?)rrr r4)rr`rs r get_usuariorh7s> ,,- Z hj),  $55rc[(dSS/SS.$URS5=(d SR5R5nURS5=(d SnURS5=(d SR5nURS 5=(d SR5n/n[R U5(dUR S 5 [U5S :aUR S 5 U(dUR S 5 US;aUR S5 U(aSUSS.$URSU45R5(a SSUS3/SS.$URSU[U5XE45nUR5 S[XR5SS.$![Ra$nUR!5 SSU3/SS.sSnA$SnAff=f)zMCrea un usuario. Devuelve {ok, usuario, status} o {ok:False, errors, status}.Fz#bcrypt no instalado en el servidor.rrr*rpasswordr6r+z7email invalido (formato esperado: usuario@dominio.tld).z*password debe tener al menos 6 caracteres.znombre requerido.)r^rz!rol debe ser 'admin' o 'cliente'.rz&SELECT 1 FROM usuarios WHERE email = ?zYa existe usuario con email .rzLINSERT INTO usuarios (email, password_hash, nombre, rol) VALUES (?, ?, ?, ?)Tr)rrrrN)rrorrrerr;rrr r$rrhrr rr) rrqr*rjr6r+rrrs rcreate_usuariorm?s :(M'NZ]^^ [[ ! 'R . . 0 6 6 8E{{:&,"Hkk(#)r 0 0 2F ;;u  # * * ,CF ??5 ! ! OP 8}q BC  )* && 9: v== || datetime('now') AND u.activo = 1 r~r`r*r6r+r)r~r`r*r6r+r)rr rrr )rr~rs r get_sessionrs  5#..#e*r/ ,,   hj {W,'Wh-5z%  rcvU(dgURSU45nUR5 URS:$)NFz$DELETE FROM sesiones WHERE token = ?r)rrrowcount)rr~rs rdelete_sessionrs3  ,,=x HCKKM <actarplanoinformecontratogarantia orden_pago certificado) r%r categoriatitulotagsrrrsha256 fecha_doc subido_porrrcU(dgURS5Vs/sH7oR5(dMUR5R5PM9 nnU(dgSR[ [ U555$s snf)zONormaliza CSV: trim, lowercase, dedup, ordenado alfabeticamente. None si vacio.N,)rrrrsortedr)tags_rawtitemss r_normalize_tags_csvrsa (0s(; I(;1wwy QWWY__ (;E I  88F3u:& '' Js B"BcU(d/$URSSR[5-S-[U5U45R 5nUVs/sHn[ U5PM sn$s snf)zCDevuelve docs existentes en la obra con mismo sha256 (dedup check).rrzJ FROM documentos WHERE obra_id = ? AND sha256 = ? ORDER BY created_at DESC)rr _DOC_FIELDSrrr)rrrrrs rfind_documento_by_sharsm  <<DIIk**.D D Wv hj  &* *TLOT ** *sA*c[X5nUc SSUS3/SS.$URS5=(d SR5R5nU[;a*SS US S R [ [55S 3/S S.$URS5=(d SR5nU(dSS/S S.$[U5S:aSS/S S.$URS5=(d SR5R5nU(a[U5S:waSS/S S.$URS5=(d SR5=(d SnU(a%[RU5(d SSUS3/S S.$U(a[U5R5(dSS/S S.$[URS5=(d S5n [XU5n URSXEXiUURS5=(d S[URS5=(d S5UUURS5=(d SURS 5=(d S4 5n UR5 [!XU R"5n S!U S"S#.n U (aXS$'U $![$R&a$nUR)5 SS%U3/S S.sSnA$SnAff=f)&u+Inserta una fila en documentos. Valida categoria (enum 8), titulo no vacio, sha256 presente. No escribe a disco — el blob ya fue guardado por el caller. Retrocompat: devuelve `{ok, documento, status, duplicados?: [...]}`. `duplicados` lista docs previos con mismo sha256 (aviso UI, no rechazo). NFrrrrrrzcategoria invalida 'z '. Validas: rrlrrztitulo es obligatorioz&titulo demasiado largo (max 200 chars)r@z*sha256 invalido (hex 64 chars obligatorio)rzfecha_doc invalida 'rzblob_path es obligatoriorz INSERT INTO documentos (obra_id, categoria, titulo, tags, blob_path, mime_type, size_bytes, sha256, fecha_doc, subido_por, notas) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) rzapplication/octet-streamrrrrTr)r documentor duplicadosr)r&rorr_DOC_CATEGORIAS_VALIDASrrrrrr rrrrr get_documentorr rr)rr"rrrrrrrrrrdocresprs rcreate_documentorst$G%x~(F'GSVWW+&,"335;;=I//&yk99V$;<=>aA   hhx &B - - /F (?'@CPP 6{S(P'Q]`aahhx &B - - / 5 5 7F S[B&CD  +&,"335=I33-i[8NOP  C N0022(B'CsSS txx/52 6D'tf=JJll F)+&D*DDHH\*/a0,'/4'"*d  " D#--8 scB !+   ! !J *QC(8'9SIIJsB= ?)z/ AND (fecha_doc IS NOT NULL AND fecha_doc <= ?)z" ORDER BY created_at DESC, id DESC) r&rrrrrr;extendrrr) rr"rtagrzr{rrrcat_normtag_normrrs rlist_documentosr_sJt$G  DIIk**. ! F??$**, 2 2I ## h 99;$$& MM jO O "      @@ e  @@ e //C << $ - - /D%) *TLOT ** *s!D9c[X5nUcgURSSR[5-S-[ U5U45R 5nU(a [ U5$S$)z;Devuelve el doc por id, solo si pertenece a la obra codigo.Nrrz- FROM documentos WHERE id = ? AND obra_id = ?)r&rrrrr r)rr"doc_idrrs rrrskt$G ,,DIIk**.' ' Vg hj  !$< --rc[XU5nUcSS/SS.$URS[U545 UR5 SUSSS .$) zXElimina fila documentos. Devuelve `{ok, blob_path}` para que el caller borre el archivo.Fzdocumento no encontradorrz#DELETE FROM documentos WHERE id = ?Tr)rrr)rrrr)rr"rrs rdelete_documentorsV f -C {(A'BcRRLL6VGKKMS%5 EEr)returnsqlite3.Connection)r sqlite3.Rowrzdict[str, Any])rrr list[dict])rrr"r rOptional[dict])rrr"r rz Optional[int])rrr"r rr)rrr"r rr)NN) rrr"r rz Optional[str]r{rrr)r>r rzOptional[_date])F)rqrrrrz list[str]r)rrrqrrrrr) rrr"r rrrr rr)NNN) rrr"r rzrr{rrrrr)rrr"r rrrr)rrr"r rqrrr) rrr"r rzrr{rrr)rr)r#r rr )r#r r'r rr)rrrr)rrrr)rrrrrztuple[bool, str])rrr*r rzOptional[sqlite3.Row])rrr`rrr)rrrqrrr)rrr`rrrrr)rrr`rrzset[int]) rurr`rr+r rvzOptional[set[int]]rzOptional[sqlite3.Connection]rr) rrr`rr+r ryr rr)rrr`rrr)rrr~r rr)rrr~r rr)rr rr)rrrrrr rr)NNNN)rrr"r rrrrrzrr{rrr)rrr"r rrrr)rrr"r rrrr)Y__doc__ __future__rr pathlibrtypingrros_osenvironror __file__parentr rrrr#r&r+r.r@rCrdrtrrrre_rerrrcompilerrr_OBRA_OPTIONAL_FIELDSrrrrrrrrrrsecretsrrrrbcryptrr ImportErrorrrerr$r(r4rB__annotations__r\rcrfrhrmrqrsrwrzrrr frozensetrrrrrrrrrrrrs #  s{{DN4I4IJ4V0WX Y+ +.& + +$1p#GT]H<+/*.''37B + +&" [[+ , KK. /   iZ37WO"/WO;?WO| 2J 2J 2J 2J 2J  2Jp  + + + +  +  +  +>. . .. .* 6J 6J 6J6J 6Jx  + + + +  +  +>6J  KK5 6 T@!"AaX\] !AbX]^ !BbX]^ "BcX]^ $d$]bc   _CL<6#JLJ((*.)- DDD D' D ' D  D"     (P*8$%  ( +  +'* +47 + +UJ UJ UJ UJ UJ  UJv $ -+ -+ -+-+  -+  -+  -+-+` .  .&) .36 . . F  F&) F36 F  FuGJsI I+*I+