diff --git a/apps/em/services.py b/apps/em/services.py
index efd935e3..c8a7719d 100644
--- a/apps/em/services.py
+++ b/apps/em/services.py
@@ -18,7 +18,7 @@ def set_eq_rs(equipId, last_timex: datetime, last_mrs: int):
         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)  # 更新数据库
     else:
-        eq_rs_cache = get_eq_rs()
+        eq_rs_cache = get_eq_rs(equipId)
 
         eq_rs_change = False
         if eq_rs_cache["running_state"] != last_mrs:  # 如果状态变动了要调用方法否则只需更新缓存