nestict/ihrm
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[UPDT] ASSET: Updated notify_expiring_assets() function add_job timeinterval

Browse Source
This commit is contained in:
Horilla
2025-09-10 15:36:09 +05:30
parent 62657fa0d1
commit a8c6777fd4
1 changed files with 18 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
asset/scheduler.py
View File

@@ -23,21 +23,29 @@ def notify_expiring_assets():
today = date.today()
assets = Asset.objects.all()
bot = User.objects.filter(username="Horilla Bot").first()
# Cache bot & superuser once
bot = User.objects.filter(username="Horilla Bot").only("id").first()
superuser = User.objects.filter(is_superuser=True).only("id").first()
# Query only assets that are expiring today
assets = Asset.objects.filter(
expiry_date__isnull=False,
expiry_date__gte=today,
)
for asset in assets:
if asset.expiry_date:
expiry_date = asset.expiry_date
notify_date = expiry_date - timedelta(days=asset.notify_before)
if notify_date == today:
recipient = getattr(asset.owner, "employee_user_id", None) or superuser
if notify_date == today and recipient:
notify.send(
bot,
recipient=asset.owner.employee_user_id,
verb=f"The Asset ' {asset.asset_name} ' expires in {asset.notify_before} days",
verb_ar=f"تنتهي صلاحية الأصل ' {asset.asset_name} ' خلال {asset.notify_before}\
من الأيام",
verb_de=f"Das Asset {asset.asset_name} läuft in {asset.notify_before} Tagen\
ab.",
recipient=recipient,
verb=f"The Asset '{asset.asset_name}' expires in {asset.notify_before} days",
verb_ar=f"تنتهي صلاحية الأصل '{asset.asset_name}' خلال {asset.notify_before} من الأيام",
verb_de=f"Das Asset {asset.asset_name} läuft in {asset.notify_before} Tagen ab.",
verb_es=f"El activo {asset.asset_name} caduca en {asset.notify_before} días.",
verb_fr=f"L'actif {asset.asset_name} expire dans {asset.notify_before} jours.",
redirect=reverse("asset-category-view"),
@@ -89,6 +97,6 @@ if not any(
for cmd in ["makemigrations", "migrate", "compilemessages", "flush", "shell"]
):
scheduler = BackgroundScheduler()
scheduler.add_job(notify_expiring_assets, "interval", hours=4)
scheduler.add_job(notify_expiring_assets, "interval", days=1)
scheduler.add_job(notify_expiring_documents, "interval", hours=4)
scheduler.start()