From 6a20445ddd47767a4a422cb76c1140721c64f58a Mon Sep 17 00:00:00 2001 From: zty Date: Wed, 14 Aug 2024 18:33:01 +0800 Subject: [PATCH] =?UTF-8?q?fix=20:=20em/service=20=E4=BF=AE=E6=94=B9update?= =?UTF-8?q?=5Ftime?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/em/services.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/apps/em/services.py b/apps/em/services.py index 6f3d4b27..d3476bcb 100644 --- a/apps/em/services.py +++ b/apps/em/services.py @@ -30,9 +30,11 @@ def set_eq_rs(equipId, last_timex: datetime, last_mrs: int): if eq_rs_cache["running_state"] != last_mrs: # 如果状态变动了要调用方法否则只需更新缓存 eq_rs_change = True update_time = now - elif now > eq_rs_cache.get('update_time', baseTime) + ten_minutes: # 如果当前时间大于缓存时间5分钟则更新 + elif now > eq_rs_cache.get('update_time', baseTime) + ten_minutes: # 如果当前时间大于缓存时间10分钟则更新 eq_rs_change = True update_time = now + else: + update_time = eq_rs_cache.get('update_time', baseTime) cache.set(f"equipment_{equipId}", {"running_state": last_mrs, "running_state_timex": last_timex, "update_time":update_time}, timeout=None) # 更新缓存 if eq_rs_change: ctask_run.delay("apps.em.services.shutdown_or_startup", equipId, last_timex, last_mrs)