ℹ️ További {int(elnyomott)} korábban már jelzett, " f"még fennálló tétel nem szerepel ebben a levélben - ezeket {int(ismetles_nap)} naponta ismételjük meg, " f"amíg a hiba fennáll.
" ) html_tartalom = f""" """ return email_sor.sorba_allit( cimek, targy, html_tartalom, kategoria="napi_riport", prioritas=email_sor.PRIORITAS_ALACSONY, company_id=company_id, db=db, ) def napi_riport_lekerdezes_es_kuldes(teszt: bool = False): """Ez a függvény fut le minden reggel, és átnézi a teljes adatbázist. ISMÉTLŐDŐ HIBÁK (2026-10-04): egy tétel (pl. egy gép lejárt vizsgálata) csak az első alkalommal kerül a riportba, utána `email_ismetles_nap` (alapból 7) napig kimarad, majd emlékeztetőként újra megjelenik, ha még fennáll. Ha egy cégnél csak ismétlődő tétel van, nem megy levél; ha egyáltalán nincs tétel, a megszokott "Minden rendben" levél megy. teszt=True (a /teszt-riport kézi indításnál): MINDEN tétel bekerül, és az ismétlés-szűrés állapotát nem olvassuk és nem módosítjuk - a teszt ne zavarja össze a valódi működést.""" db = SessionLocal() try: mai_nap = date.today() figyelmezteto_hatar = mai_nap + timedelta(days=30) is_monday = (mai_nap.weekday() == 0) # Hétfő = 0 korlat = email_sor.korlatok_betolt(db) tipus_cimke = { "Szerkezeti vizsgálat": "Szerkezeti vizsg", "Fővizsgálat": "Fővizsgálat", "Időszakos biztonsági felülvizsgálat (EBSZ)": "Biztonsági felülvizsg", } config_cache = {} kotelezo_mod_cache = {} def get_config(company_id, geptipus): key = (company_id, geptipus) if key not in config_cache: config_cache[key] = db.query(models.MachineTypeConfig).filter( models.MachineTypeConfig.company_id == company_id, models.MachineTypeConfig.geptipus == geptipus ).first() return config_cache[key] def get_kotelezo_mod(company_id): if company_id not in kotelezo_mod_cache: kotelezo_mod_cache[company_id] = get_vizsgalati_datum_kotelezo_mod(company_id, db) return kotelezo_mod_cache[company_id] cegek = db.query(models.Company).filter(models.Company.aktiv == True).all() for ceg in cegek: try: _ceg_riport(db, ceg, mai_nap, figyelmezteto_hatar, is_monday, korlat, teszt, tipus_cimke, get_config, get_kotelezo_mod) except Exception as e: # Egy cég hibája ne akadályozza a többi cég riportját db.rollback() print(f"❌ Hiba a napi riport generálása közben (cég #{ceg.id}): {type(e).__name__}: {e}") except Exception as e: db.rollback() print(f"❌ Hiba a napi riport generálása közben: {str(e)}") finally: db.close() def _ceg_riport(db, ceg, mai_nap, figyelmezteto_hatar, is_monday, korlat, teszt, tipus_cimke, get_config, get_kotelezo_mod): """Egy cég napi riportja: tételek gyűjtése -> ismétlés-szűrés -> sorba állítás (egy tranzakció).""" beallitas = db.query(models.Dictionary).filter( models.Dictionary.company_id == ceg.id, models.Dictionary.kategoria == "EmailRiportGyakorisag" ).first() gyak = beallitas.ertek if beallitas else "Kikapcsolva" # Ha ki van kapcsolva, vagy hétfői a beállítás de ma nem hétfő van, ugorjuk át if gyak == "Kikapcsolva": return if gyak == "Heti" and not is_monday: return # Tételek: (stabil kulcs, kész html) - a kulcs azonosítja a hibát az ismétlés-szűréshez. # A kulcsba a hiba ÁLLAPOTA ("lejart"/"hamarosan") és az utolsó vizsgálat/lejárat dátuma is beleszámít: # ha egy vizsgálat "hamarosan"-ból "lejárt"-ra vált, vagy új vizsgálat történik, az új információ -> új levél. lejart_lista = [] hamarosan_lista = [] # 1. GÉPEK ELLENŐRZÉSE (Egyszerűsített dátumellenőrzés) - a saját gépek mellett # az aktív bérlettel a céghez kihelyezett (más cég tulajdonában lévő) gépek is bekerülnek. berelt_gep_idk = berelt_gep_idk_a_ceghez(ceg.id, db) gepek_query = db.query(models.Machine).filter(models.Machine.statusz == "Aktív") if berelt_gep_idk: gepek_query = gepek_query.filter( (models.Machine.company_id == ceg.id) | (models.Machine.id.in_(berelt_gep_idk)) ) else: gepek_query = gepek_query.filter(models.Machine.company_id == ceg.id) gepek = gepek_query.all() for gep in gepek: gep_nev = f"GÉP: {_e(gep.megnevezes)} ({_e(gep.gyari_szam)})" # Műszaki vizsga (Közúti forgalom) if gep.kozuti_forgalom and gep.kozuti_vizsga_datum: if gep.kozuti_vizsga_datum < mai_nap: lejart_lista.append((f"gep:{gep.id}:kozuti:lejart:{gep.kozuti_vizsga_datum}", f"{gep_nev} - Lejárt Műszaki vizsga: {gep.kozuti_vizsga_datum}")) elif gep.kozuti_vizsga_datum <= figyelmezteto_hatar: hamarosan_lista.append((f"gep:{gep.id}:kozuti:hamarosan:{gep.kozuti_vizsga_datum}", f"{gep_nev} - Lejáró Műszaki vizsga: {gep.kozuti_vizsga_datum}")) # --- SZIGORÚ DÁTUM ELLENŐRZÉS AZ E-MAILBEN IS --- a naptár/PDF-fel közös # MSZ 9750 / EBSZ esedékesség-számítással (hónap ÉS üzemóra alapján, amelyik # előbb bekövetkezik - l. compute_vizsgalati_esedekesseg). config = get_config(gep.company_id, gep.geptipus) datum_kotelezo_mod = get_kotelezo_mod(gep.company_id) for e in compute_vizsgalati_esedekesseg(gep, mai_nap, config, datum_kotelezo_mod): cimke = _e(tipus_cimke.get(e["tipus"], e["tipus"])) # FONTOS: a kulcsba az UTOLSÓ VIZSGÁLAT dátuma kerül, NEM a számított esedékesség - az üzemóra-alapú # esedékesség a mai naphoz képest számolódik, így szinte naponta változik, és a kulcs ezért napról # napra más lenne (az ismétlés-szűrés soha nem fogna). Az utolsó vizsgálat dátuma csak akkor # változik, ha tényleg megtörtént egy új vizsgálat. kulcs = f"gep:{gep.id}:{e['tipus']}:{e['allapot']}:{e.get('utolso')}" if e["allapot"] == "hianyzik": lejart_lista.append((kulcs, f"{gep_nev} - Hiányzó {cimke} dátum!")) elif e["allapot"] == "lejart": lejart_lista.append((kulcs, f"{gep_nev} - Lejárt {cimke}: {e['esedekes']}")) elif e["allapot"] == "hamarosan": hamarosan_lista.append((kulcs, f"{gep_nev} - Lejáró {cimke}: {e['esedekes']}")) # 2. HR (GÉPKEZELŐK) ELLENŐRZÉSE dolgozok = db.query(models.User).filter( models.User.company_id == ceg.id, models.User.role.in_(["Felhasználó", "Emelőgép ügyintéző"]) ).all() for d in dolgozok: dolgozo_nev = f"DOLGOZÓ: {_e(d.username)}" if d.orvosi_alkalmassag_ervenyesseg: if d.orvosi_alkalmassag_ervenyesseg < mai_nap: lejart_lista.append((f"dolgozo:{d.id}:orvosi:lejart:{d.orvosi_alkalmassag_ervenyesseg}", f"{dolgozo_nev} - Lejárt Orvosi alkalmassági: {d.orvosi_alkalmassag_ervenyesseg}")) elif d.orvosi_alkalmassag_ervenyesseg <= figyelmezteto_hatar: hamarosan_lista.append((f"dolgozo:{d.id}:orvosi:hamarosan:{d.orvosi_alkalmassag_ervenyesseg}", f"{dolgozo_nev} - Lejáró Orvosi alkalmassági: {d.orvosi_alkalmassag_ervenyesseg}")) if d.jogositvany_ervenyesseg: if d.jogositvany_ervenyesseg < mai_nap: lejart_lista.append((f"dolgozo:{d.id}:jogositvany:lejart:{d.jogositvany_ervenyesseg}", f"{dolgozo_nev} - Lejárt Targonca jogosítvány: {d.jogositvany_ervenyesseg}")) elif d.jogositvany_ervenyesseg <= figyelmezteto_hatar: hamarosan_lista.append((f"dolgozo:{d.id}:jogositvany:hamarosan:{d.jogositvany_ervenyesseg}", f"{dolgozo_nev} - Lejáró Targonca jogosítvány: {d.jogositvany_ervenyesseg}")) # Címzettek keresése az adott cégben # C szelet: a címzetteket a céges szabály + a felhasználói feliratkozás adja (lejarati_riport kategória); # alapból az Admin és az EÜI - ahogy korábban -, de ők ki is kapcsolhatják, mások be is kérhetik. cimzettek = email_feliratkozas.cimzett_felhasznalok(db, ceg.id, "lejarati_riport") # A TELJES riport (a dolgozók orvosi alkalmasságával, jogosítványával együtt) csak az Admin/EÜI címzetteknek # megy; a többi szerepkörnek (akit a cégadmin kapcsolt be) a dolgozói (HR) szakasz nélküli változat. cimek_teljes = email_sor.cimek_tisztitasa( [u.email for u in cimzettek if u.role in email_feliratkozas.ALAP_CIMZETT_SZEREPKOROK]) cimek_korlatozott = [c for c in email_sor.cimek_tisztitasa( [u.email for u in cimzettek if u.role not in email_feliratkozas.ALAP_CIMZETT_SZEREPKOROK]) if c not in cimek_teljes] # Ha nincs kinek küldeni, nincs teendő - az ismétlés-szűrés állapotához sem nyúlunk if not cimek_teljes and not cimek_korlatozott: return def hr_e(kulcs: str) -> bool: return kulcs.startswith("dolgozo:") if teszt: kuldendo = [("l", h, hr_e(k)) for k, h in lejart_lista] + [("h", h, hr_e(k)) for k, h in hamarosan_lista] elnyomott = 0 else: # Ismétlés-szűrés: az új és a 7 napja emlékeztetett tételek maradnak, a többi kimarad. osszes = ([(k, ("l", h, hr_e(k))) for k, h in lejart_lista] + [(k, ("h", h, hr_e(k))) for k, h in hamarosan_lista]) kuldendo, elnyomott = email_sor.riport_tetelek_szurese(db, ceg.id, osszes, korlat.ismetles_nap, mai_nap) ures_riport = not lejart_lista and not hamarosan_lista # tényleg nincs semmi -> "Minden rendben" osszes_tetel = len(lejart_lista) + len(hamarosan_lista) nem_hr_osszes = sum(1 for k, _ in lejart_lista + hamarosan_lista if not hr_e(k)) # (címzettek, mely tételek kerülhetnek bele, a változatban összesen hány tétel van) for cimzettek_csoport, hr_is, valtozat_osszes in ((cimek_teljes, True, osszes_tetel), (cimek_korlatozott, False, nem_hr_osszes)): if not cimzettek_csoport: continue resz = [(cs, h) for cs, h, hr in kuldendo if hr_is or not hr] kuldendo_lejart = [h for cs, h in resz if cs == "l"] kuldendo_hamarosan = [h for cs, h in resz if cs == "h"] elnyomott_valtozat = elnyomott if hr_is else (max(0, valtozat_osszes - len(resz)) if not teszt else 0) # Az "üres" változat: a teljes riportnál ures_riport ("Minden rendben"); a HR-mentesnél ugyanez, de ha # csak HR-tétel van, nem küldünk semmit (ne menjen "Minden rendben" olyankor, amikor van - számára # láthatatlan - tétel), és az ismétlődő-csak változatnál sem megy levél. csak_ismetlodo = not kuldendo_lejart and not kuldendo_hamarosan and valtozat_osszes > 0 if (not ures_riport and valtozat_osszes == 0) or csak_ismetlodo: continue send_summary_email_task( cimzettek_csoport, ceg.nev, kuldendo_lejart, kuldendo_hamarosan, elnyomott=elnyomott_valtozat, ismetles_nap=korlat.ismetles_nap, company_id=ceg.id, db=db, ) db.commit() # a sorba állított levél és az ismétlés-szűrés állapota EGY tranzakcióban mentődik