radarsys_met Commit - r205:2b52673784ab

Task #769: Implementacion Scheduler para ABS, Task #717: Implementacion de start_device() y stop_device()...

Fiorella Quino -

r205:2b52673784ab

parent child

Context file:

r205:2b52673784ab

Collapse all files

apps/abs/models.py +45 -7

              from apps.main.models import Configuration
              from django.core.urlresolvers import reverse
              # Create your models here.
+             from celery.execute import send_task
+             from datetime import datetime
              import ast
              import socket
              import json
                  operation_mode  = models.PositiveSmallIntegerField(verbose_name='Operation Mode', choices=OPERATION_MODES, default = 0)
                  operation_value = models.FloatField(verbose_name='Periodic (seconds)', default="10", null=True, blank=True)
                  module_messages = models.CharField(verbose_name='Modules Messages', max_length=10000, default=json.dumps(default_messages))
                  class Meta:
                      db_table = 'abs_configurations'
                      active_beam = json.loads(self.active_beam)
                      new_beams = ABSBeam.objects.filter(abs_conf=self)
                      active_beam['active_beam'] = new_beams[0].id
                      self.active_beam = json.dumps(active_beam)
                      self.save()
                      #-----For Active Beam-----
+                     #-----For Device Status---
+                     self.device.status = 3
+                     self.device.save()
+                     #-----For Device Status---
                      return self
+                 def start_device(self):
+                     if self.device.status == 3:
+                         try:
+                             #self.write_device()
+                             send_task('task_change_beam', [self.id],)
+                             self.message = 'ABS running'
+                         except Exception as e:
+                             self.message = str(e)
+                             return False
+                         return True
+                     else:
+                         self.message = 'Please, select Write ABS Device first.'
+                         return False
+                 def stop_device(self):
+                     self.device.status = 2
+                     self.device.save()
+                     self.message = 'ABS has been stopped.'
+                     self.save()
+                     return True
                  def module_conf(self, module_num, beams):
                      """
                      This function creates beam configurations for one abs module.
                  def write_device(self):
                      """
                      This function sends the beams list to every abs module.
                      It needs 'module_conf' function
                      beams = ABSBeam.objects.filter(abs_conf=self)
                      connected_modules = ast.literal_eval(self.module_status)
                      suma_connected_modules = 0
                      for c in connected_modules:
                          suma_connected_modules = suma_connected_modules+connected_modules[c]
                      if not suma_connected_modules > 0 :
                                      pass
                              else:
                                  disconnected_modules += 1
                      else:
                          self.message = "ABS Configuration does not have beams"
                          return False
                      #-------------Jueves-------------
                      if disconnected_modules == 64:
                          self.message = "Could not write ABS Modules"
+                         self.device.status = 0
                          return False
                      else:
                          self.message = "ABS Beams List have been sent to ABS Modules"
                          beams[0].set_as_activebeam()
+                     self.device.status = 3
                      self.module_status = json.dumps(beams_status)
-                     self.save()
                      self.save()
                      return True

apps/abs/tasks.py +5 -14

              from datetime import timedelta, datetime
              from celery.task import task
-             """
-             @task
-             def beam_task(id_conf):
-                 abs_conf  = Configuration.objects.get(pk=id_conf)
-                 task_change_beam(abs_conf.pk)
-                 return task_change_beam(abs_conf.pk)
-             """
-             @task
+             @task(name='task_change_beam')
              def task_change_beam(id_conf):
                  abs_conf = Configuration.objects.get(pk=id_conf)
                  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
                          abs_conf.send_beam_num(1)
                          beams_list[0].set_as_activebeam()
                          task = task_change_beam.apply_async((abs_conf.pk,), eta=date)
-                         print next_beam
+                         print beams_list[0]
                          i=0
                  else:

apps/abs/views.py +3 -3

              from time import sleep
              import os
-             from apps.main.models import Device, Configuration
+             from apps.main.models import Device, Configuration, Experiment
              from apps.main.views import sidebar
              from .models import ABSConfiguration, ABSBeam
                  kwargs['title'] = 'ABS Configuration'
                  kwargs['suptitle'] = 'Details'
-                 kwargs['no_play'] = True
+                 #kwargs['no_play'] = True
                  kwargs['button'] = 'Edit Configuration'
                  #------------------Active Beam-----------------------
                  kwargs['color_status']   = color_status
                  kwargs['module_messages'] = module_messages
-                 kwargs['only_stop'] = True
+                 #kwargs['only_stop'] = True
                  ###### SIDEBAR ######
                  kwargs.update(sidebar(conf=conf))

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages