fix: check_equipment_offline后需更新缓存
This commit is contained in:
parent
8b8b65c8ba
commit
9600e95272
|
|
@ -5,6 +5,7 @@ from celery import shared_task
|
||||||
from django.utils import timezone
|
from django.utils import timezone
|
||||||
from apps.em.models import Equipment
|
from apps.em.models import Equipment
|
||||||
from django.core.cache import cache
|
from django.core.cache import cache
|
||||||
|
from apps.em.services import set_equip_rs
|
||||||
|
|
||||||
|
|
||||||
@shared_task(base=CustomTask)
|
@shared_task(base=CustomTask)
|
||||||
|
|
@ -26,3 +27,4 @@ def check_equipment_offline(seconds=30):
|
||||||
if is_offline and equip.running_state != Equipment.OFFLINE:
|
if is_offline and equip.running_state != Equipment.OFFLINE:
|
||||||
equip.running_state = Equipment.OFFLINE
|
equip.running_state = Equipment.OFFLINE
|
||||||
equip.save(update_fields=["running_state"])
|
equip.save(update_fields=["running_state"])
|
||||||
|
set_equip_rs(equip.id, now, Equipment.OFFLINE)
|
||||||
Loading…
Reference in New Issue