|
|
from __future__ import absolute_import
|
|
|
|
|
|
from apps.main.models import Configuration
|
|
|
from .models import ABSBeam
|
|
|
import json
|
|
|
from datetime import timedelta, datetime
|
|
|
from celery.task import task
|
|
|
|
|
|
@task(name='task_change_beam')
|
|
|
def task_change_beam(id_conf):
|
|
|
|
|
|
abs_conf = Configuration.objects.get(pk=id_conf)
|
|
|
beams_list = ABSBeam.objects.filter(abs_conf=abs_conf)
|
|
|
active_beam = json.loads(abs_conf.active_beam)
|
|
|
|
|
|
run_every = timedelta(seconds=abs_conf.operation_value)
|
|
|
now = datetime.utcnow()
|
|
|
date = now + run_every
|
|
|
|
|
|
if abs_conf.device.status != 3:
|
|
|
return abs_conf.device.status
|
|
|
|
|
|
if abs_conf.operation_mode == 0: #Manual Mode
|
|
|
return 1
|
|
|
|
|
|
if active_beam:
|
|
|
current_beam = ABSBeam.objects.get(pk=active_beam['active_beam'])
|
|
|
i=0
|
|
|
for beam in beams_list:
|
|
|
if beam == current_beam:
|
|
|
i+=1
|
|
|
break
|
|
|
i+=1
|
|
|
|
|
|
if i < len(beams_list):
|
|
|
next_beam = beams_list[i]
|
|
|
abs_conf.send_beam_num(i+1)
|
|
|
next_beam.set_as_activebeam()
|
|
|
task = task_change_beam.apply_async((abs_conf.pk,), eta=date)
|
|
|
print next_beam
|
|
|
else:
|
|
|
abs_conf.send_beam_num(1)
|
|
|
beams_list[0].set_as_activebeam()
|
|
|
task = task_change_beam.apply_async((abs_conf.pk,), eta=date)
|
|
|
print beams_list[0]
|
|
|
i=0
|
|
|
|
|
|
else:
|
|
|
abs_conf.send_beam_num(1)
|
|
|
beams_list[0].set_as_activebeam()
|
|
|
task = task_change_beam.apply_async((abs_conf.pk,), eta=date)
|
|
|
|
|
|
|
|
|
return 2
|
|
|
|
|
|
|
|
|
@task(name='status_absdevice')
|
|
|
def status_absdevice(id_conf):
|
|
|
|
|
|
abs_conf = Configuration.objects.get(pk=id_conf)
|
|
|
abs_conf.absmodule_status()
|
|
|
|
|
|
return
|
|
|
|
