diff --git a/apps/enm/services.py b/apps/enm/services.py index 3b137b48..5d36b48f 100644 --- a/apps/enm/services.py +++ b/apps/enm/services.py @@ -134,7 +134,7 @@ def update_mpoint_cache(cache_key: str, current_cache_val: dict, last_timex: dat if ep_monitored_id: cache.set(f"equipment_{ep_monitored_id}", {"running_state": last_mrs, "running_state_timex": last_timex}, timeout=None) # 如果state变动则触发函数 - if last_data["pre_mrs"] != last_mrs: + if last_data["pre_mrs"] != last_mrs or (timezone.now()-last_timex).total_seconds()>30: if ep_belong_id: ctask_run("apps.em.services.shutdown_or_startup", ep_belong_id, last_timex, Equipment.RUNING) if ep_monitored_id: