From 13adb0d4ea4eea575125cbd9139be2ac099c7470 Mon Sep 17 00:00:00 2001
From: caoqianming <caoqianming@foxmail.com>
Date: Sun, 28 Apr 2024 15:19:32 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E6=B7=BB=E5=8A=A0=E4=B8=80=E5=A4=84log?=
 =?UTF-8?q?=E4=BB=A5=E5=AE=9A=E4=BD=8D=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 apps/em/services.py | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

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"])