fix: shutdown_or_startup 启动
This commit is contained in:
parent
601bb0ae60
commit
85fce01834
|
|
@ -4,7 +4,6 @@ from apps.mtm.models import Mgroup
|
||||||
import datetime
|
import datetime
|
||||||
from django.core.cache import cache
|
from django.core.cache import cache
|
||||||
from django.utils.timezone import localtime
|
from django.utils.timezone import localtime
|
||||||
from apps.utils.tasks import ctask_run
|
|
||||||
|
|
||||||
def get_eq_rs(equipId: str):
|
def get_eq_rs(equipId: str):
|
||||||
"""获取设备运行状态缓存
|
"""获取设备运行状态缓存
|
||||||
|
|
@ -26,7 +25,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) # 更新缓存
|
cache.set(f"equipment_{equipId}", {"running_state": last_mrs, "running_state_timex": last_timex}, timeout=None) # 更新缓存
|
||||||
if eq_rs_change:
|
if eq_rs_change:
|
||||||
ctask_run.delay("apps.em.services.shutdown_or_startup", equipId, last_timex, last_mrs)
|
shutdown_or_startup(equipId, last_timex, last_mrs)
|
||||||
|
|
||||||
|
|
||||||
def shutdown_or_startup(equipId: str, last_timex: datetime, last_mrs):
|
def shutdown_or_startup(equipId: str, last_timex: datetime, last_mrs):
|
||||||
|
|
|
||||||
|
|
@ -11,7 +11,6 @@ from django.db import connection, transaction
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
from apps.utils.decorators import auto_log
|
from apps.utils.decorators import auto_log
|
||||||
from django.db import IntegrityError
|
from django.db import IntegrityError
|
||||||
from apps.utils.tasks import ctask_run
|
|
||||||
from .serializers import MpointSerializer
|
from .serializers import MpointSerializer
|
||||||
from apps.enp.models import EnvData
|
from apps.enp.models import EnvData
|
||||||
from apps.em.models import Equipment
|
from apps.em.models import Equipment
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue