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

feat: 添加一处log以定位问题

This commit is contained in:
caoqianming 2024-04-28 15:19:32 +08:00
parent 107f0fc61d
commit 13adb0d4ea
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
apps/em/services.py
View File

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