feat: 先打一个日志看看啥情况
This commit is contained in:
parent
1cb9b3495a
commit
451e1e7eae
|
@ -18,6 +18,8 @@ def get_eq_rs(equipId: str):
|
|||
def set_eq_rs(equipId, last_timex: datetime, last_mrs: int):
|
||||
"""更新设备运行状态(包括缓存和数据库)
|
||||
"""
|
||||
if equipId == '3574620497738379264' and last_mrs == Equipment.RUNING:
|
||||
myLogger.error(f'{equipId} {last_timex} {last_mrs}')
|
||||
if last_mrs == Equipment.OFFLINE: # 如果是离线直接更新
|
||||
cache.set(f"equipment_{equipId}", {"running_state": last_mrs, "running_state_timex": last_timex}, timeout=None) # 更新缓存
|
||||
Equipment.objects.filter(id=equipId).update(running_state=last_mrs) # 更新数据库
|
||||
|
|
Loading…
Reference in New Issue