diff --git a/apps/em/services.py b/apps/em/services.py
index 8bcab525..464713c5 100644
--- a/apps/em/services.py
+++ b/apps/em/services.py
@@ -4,6 +4,9 @@ from apps.mtm.models import Mgroup
 import datetime
 from django.core.cache import cache
 from django.utils.timezone import localtime
+from apps.utils.tasks import ctask_run
+import logging
+myLogger = logging.getLogger("log")
 
 def get_eq_rs(equipId: str):
     """获取设备运行状态缓存
@@ -25,7 +28,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) # 更新缓存
         if eq_rs_change:
-            shutdown_or_startup(equipId, last_timex, last_mrs)
+            ctask_run.delay("apps.em.services.shutdown_or_startup", equipId, last_timex, last_mrs)
 
 
 def shutdown_or_startup(equipId: str, last_timex: datetime, last_mrs):
@@ -36,6 +39,7 @@ def shutdown_or_startup(equipId: str, last_timex: datetime, last_mrs):
     from apps.wpm.tasks import cal_exp_duration_hour
     from apps.wpm.services import get_sflog
 
+    myLogger.error(f"{equipId} {last_timex} {last_mrs}")
     equip = Equipment.objects.get(id=equipId)
     equip.running_state = last_mrs
     equip.save(update_fields=["running_state"])