zcdsj
/
factory
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: em.service.py 更改状态变动

This commit is contained in:
zty 2024-08-12 10:32:34 +08:00
parent 169a31da5a
commit a6d5604acb
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
apps/em/services.py
View File

@ -27,9 +27,11 @@ def set_eq_rs(equipId, last_timex: datetime, last_mrs: int):
eq_rs_change = False eq_rs_change = False
if eq_rs_cache["running_state"] != last_mrs: # 如果状态变动了要调用方法否则只需更新缓存 if eq_rs_cache["running_state"] != last_mrs: # 如果状态变动了要调用方法否则只需更新缓存
eq_rs_change = True eq_rs_change = True
elif eq_rs_cache.get('update_num', 0) >= 20: # 如果状态没有变动但是更新次数大于20次也要调用方法 update_num = 0
elif eq_rs_cache.get('update_num', 0) >= 10: # 如果状态没有变动但是更新次数大于20次也要调用方法
eq_rs_change = True eq_rs_change = True
update_num = 0
else:
update_num = eq_rs_cache.get('update_num', 0) + 1 update_num = eq_rs_cache.get('update_num', 0) + 1
cache.set(f"equipment_{equipId}", {"running_state": last_mrs, "running_state_timex": last_timex, "update_num":update_num}, timeout=None) # 更新缓存 cache.set(f"equipment_{equipId}", {"running_state": last_mrs, "running_state_timex": last_timex, "update_num":update_num}, timeout=None) # 更新缓存
if eq_rs_change: if eq_rs_change: