radarsys Commit - r181:ea9394e8ace0 · Jicamarca Repository

Task #714: Modulo Web ABS...

Fiorella Quino -

r181:ea9394e8ace0

parent child

Context file:

r181:ea9394e8ace0

Collapse all files

apps/abs/models.py +163 -26

             from django.db import models
             from apps.main.models import Configuration
             from django.core.urlresolvers import reverse
             # Create your models here.
             import ast
             import socket
             import json
             import requests
             import struct
             import sys, time
             import multiprocessing
             antenna_default = json.dumps({
                                 "antenna_up": [[0.0,0.0,0.0,0.0,0.5,0.5,0.5,0.5],
                                                 [0.0,0.0,0.0,0.0,0.5,0.5,0.5,0.5],
                                                 [0.0,0.0,0.0,0.0,0.5,0.5,0.5,0.5],
                                                 [0.0,0.0,0.0,0.0,0.5,0.5,0.5,0.5],
                                                 [0.5,0.5,0.5,0.5,1.0,1.0,1.0,1.0],
                                                 [0.5,0.5,0.5,0.5,1.0,1.0,1.0,1.0],
                                                 [0.5,0.5,0.5,0.5,1.0,1.0,1.0,1.0],
                                                 [0.5,0.5,0.5,0.5,1.0,1.0,1.0,1.0]
                                                 ]
                                                ,
                                 "antenna_down": [[0.0,0.0,0.0,0.0,0.5,0.5,0.5,0.5],
                                                 [0.0,0.0,0.0,0.0,0.5,0.5,0.5,0.5],
                                                 [0.0,0.0,0.0,0.0,0.5,0.5,0.5,0.5],
                                                 [0.0,0.0,0.0,0.0,0.5,0.5,0.5,0.5],
                                                 [0.5,0.5,0.5,0.5,3.0,3.0,3.0,3.0],
                                                 [0.5,0.5,0.5,0.5,3.0,3.0,3.0,3.0],
                                                 [0.5,0.5,0.5,0.5,3.0,3.0,3.0,3.0],
                                                 [0.5,0.5,0.5,0.5,3.0,3.0,3.0,3.0]],
                             })
             tx_default = json.dumps({
                             "up": [[1,1,1,1,0,0,0,0],
                                    [1,1,1,1,0,0,0,0],
                                    [1,1,1,1,0,0,0,0],
                                    [1,1,1,1,0,0,0,0],
                                    [0,0,0,0,1,1,1,1],
                                    [0,0,0,0,1,1,1,1],
                                    [0,0,0,0,1,1,1,1],
                                    [0,0,0,0,1,1,1,1]],
                           "down": [[1,1,1,1,0,0,0,0],
                                    [1,1,1,1,0,0,0,0],
                                    [1,1,1,1,0,0,0,0],
                                    [1,1,1,1,0,0,0,0],
                                    [0,0,0,0,1,1,1,1],
                                    [0,0,0,0,1,1,1,1],
                                    [0,0,0,0,1,1,1,1],
                                    [0,0,0,0,1,1,1,1]],
                          })
             rx_default = json.dumps({
                             "up": [[1,1,1,1,0,0,0,0],
                                    [1,1,1,1,0,0,0,0],
                                    [1,1,1,1,0,0,0,0],
                                    [1,1,1,1,0,0,0,0],
                                    [0,0,0,0,1,1,1,1],
                                    [0,0,0,0,1,1,1,1],
                                    [0,0,0,0,1,1,1,1],
                                    [0,0,0,0,1,1,1,1]],
                           "down": [[1,1,1,1,0,0,0,0],
                                    [1,1,1,1,0,0,0,0],
                                    [1,1,1,1,0,0,0,0],
                                    [1,1,1,1,0,0,0,0],
                                    [0,0,0,0,1,1,1,1],
                                    [0,0,0,0,1,1,1,1],
                                    [0,0,0,0,1,1,1,1],
                                    [0,0,0,0,1,1,1,1]],
                          })
             conf_default = {}
             status_default = {}
             for i in range(1,65):
                 conf_default[str(i)] = ""
                 status_default[str(i)] = 0
             ues_default = json.dumps({
                             "up": [0.533333,0.00000,1.06667,0.00000],
                             "down": [0.533333,0.00000,1.06667,0.00000]
                         })
             onlyrx_default = json.dumps({
                                 "up": False,
                                 "down": False
                             })
             def up_convertion(cadena):
                 valores = []
                 for c in cadena:
                     if c == 1.0: valores=valores+['000']
                     if c == 2.0: valores=valores+['001']
                     if c == 3.0: valores=valores+['010']
                     if c == 0.0: valores=valores+['011']
                     if c == 0.5: valores=valores+['100']
                     if c == 1.5: valores=valores+['101']
                     if c == 2.5: valores=valores+['110']
                     if c == 3.5: valores=valores+['111']
                 return valores
             def up_conv_bits(value):
                 if value == 1.0: bits="000"
                 if value == 2.0: bits="001"
                 if value == 3.0: bits="010"
                 if value == 0.0: bits="011"
                 if value == 0.5: bits="100"
                 if value == 1.5: bits="101"
                 if value == 2.5: bits="110"
                 if value == 3.5: bits="111"
                 return bits
             def down_convertion(cadena):
                 valores = []
                 for c in cadena:
                     if c == 1.0: valores=valores+['000']
                     if c == 2.0: valores=valores+['001']
                     if c == 3.0: valores=valores+['010']
                     if c == 0.0: valores=valores+['011']
                     if c == 0.5: valores=valores+['100']
                     if c == 1.5: valores=valores+['101']
                     if c == 2.5: valores=valores+['110']
                     if c == 3.5: valores=valores+['111']
                 return valores
             def down_conv_bits(value):
                 if value == 1.0: bits="000"
                 if value == 2.0: bits="001"
                 if value == 3.0: bits="010"
                 if value == 0.0: bits="011"
                 if value == 0.5: bits="100"
                 if value == 1.5: bits="101"
                 if value == 2.5: bits="110"
                 if value == 3.5: bits="111"
                 return bits
             def ip2position(module_number):
                 j=0
                 i=0
                 for x in range(0,module_number-1):
                     j=j+1
                     if j==8:
                         i=i+1
                         j=0
                 pos = [i,j]
                 return pos
+            def fromBinary2Char(binary_string):
+                number = int(binary_string, 2)
+                #Plus 33 to avoid more than 1 characters values such as: '\x01'-'\x1f'
+                number = number + 33
+                char = chr(number)
+                return char
+            def fromChar2Binary(char):
+                number = ord(char) - 33
+                #Minus 33 to get the real value
+                bits = bin(number)[2:]
+                #To ensure we have a string with 6bits
+                if len(bits) < 6:
+                    bits = bits.zfill(6)
+                return bits
             def change_beam_for_multiprocessing(module):
             	for i in range (1,50):
             	    beam_pos = 0
             	    module_address = ('192.168.1.'+str(module), 5500)
             	    header   = 'JROABSCeCnModCnMod0100000'
             	    numbers  = len(str(beam_pos))
             	    function = 'CHGB'
             	    message_tx = header+str(numbers)+function+str(beam_pos)+'0'
             	    # Create the datagram socket
             	    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
             	    sock.connect(module_address)
             	    sock.send(message_tx)
             	    #t = sock.recv(1024)
             	    sock.close()
             	    sock = None
             	    time.sleep(0.2)
             	    beam_pos = 1
             	    numbers  = len(str(beam_pos))
             	    message_tx = header+str(numbers)+function+str(beam_pos)+'0'
             	    # Create the datagram socket
             	    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
             	    sock.connect(module_address)
             	    sock.send(message_tx)
             	    sock.close()
             	    sock = None
             	    time.sleep(0.2)
             class ABSConfiguration(Configuration):
                 beams         = models.CharField(verbose_name='Beams', max_length=20000, default="{}")
                 module_status = models.CharField(verbose_name='Module Status', max_length=10000, default=json.dumps(status_default))
                 class Meta:
                     db_table = 'abs_configurations'
                 def get_absolute_url_plot(self):
                     return reverse('url_plot_abs_patterns', args=[str(self.id)])
                 def parms_to_dict(self):
                     parameters = {}
                     parameters['device_id'] = self.device.id
                     parameters['name']      = self.name
                     parameters['beams']     = {}
                     beams = ast.literal_eval(self.beams)
                     b=1
                     for beam in beams:
                         absbeam = ABSBeam.objects.get(pk=beams[beam])
                         parameters['beams']['beam'+str(b)] = absbeam.parms_to_dict()
                         b+=1
                     return parameters
+                def get_beams(self, **kwargs):
+                    '''
+                    This function returns ABS Configuration beams
+                    '''
+                    return ABSBeam.objects.filter(abs_conf=self.pk, **kwargs)
+                def clone(self, **kwargs):
+                    beams = self.get_beams()
+                    self.pk = None
+                    self.id = None
+                    for attr, value in kwargs.items():
+                        setattr(self, attr, value)
+                    self.save()
+                    for beam in beams:
+                        beam.clone(abs_conf=self)
+                    return self
                 def module_conf(self, module_num, beams):
                     """
                     This function creates beam configurations for one abs module.
                     """
                     ip_address  = self.device.ip_address
                     ip_address  = ip_address.split('.')
                     module_seq  = (ip_address[0],ip_address[1],ip_address[2])
                     dot         = '.'
                     module_ip   = dot.join(module_seq)+'.'+str(module_num)
                     module_port = self.device.port_address
                     write_route = 'http://'+module_ip+':'+str(module_port)+'/configure'
                     header = 'JROABSCeCnModCnMod01000108SNDFexperimento1.ab1'
                     module = 'ABS_'+str(module_num)
-                    bs  = {}
+                    bs  = '' #{}
                     i=1
                     #beams  = {1: '001000', 2: '010001', 3: '010010', 4: '000011', 5: '101100', 6: '101101',
                     #       7: '110110', 8: '111111', 9: '000000', 10: '001001', 11: '010010', 12: '011011'}
                     for beam in beams:
-                        bs[i] = beam.module_6bits(module_num)
+                        #bs[i] = fromBinary2Char(beam.module_6bits(module_num))
+                        bs = bs + fromBinary2Char(beam.module_6bits(module_num))
                         i=i+1
                     beams = bs
                     parameters = {}
                     parameters['header'] = header
                     parameters['module'] = module
-                    parameters['beams']  = json.dumps(beams)
+                    parameters['beams']  = beams #json.dumps(beams)
+                    print parameters['beams']
                     answer = ''
                     try:
                         r_write = requests.post(write_route, parameters, timeout=0.5)
                         answer  = r_write.json()
                         self.message = answer['message']
                     except:
                         self.message = "Could not write ABS parameters"
                         return 0
                     return 1
                 def read_module(self, module):
                     """
                     Read out-bits (up-down) of 1 abs module NOT for Configuration
                     """
                     parameters = {}
                     ip_address  = self.device.ip_address
                     ip_address  = ip_address.split('.')
                     module_seq  = (ip_address[0],ip_address[1],ip_address[2])
                     dot         = '.'
                     module_ip   = dot.join(module_seq)+'.'+str(module)
                     module_port = self.device.port_address
                     read_route = 'http://'+module_ip+':'+str(module_port)+'/read'
                     print(read_route)
                     answer = ''
                     module_bits = ''
                     try:
                         r_write = requests.get(read_route, timeout=0.7)
                         answer  = r_write.json()
-                        message = answer['message']
+                        self.message = answer['message']
                         module_bits    = answer['allbits']
                     except:
-                        message = "Could not read ABS parameters"
+                        #message = "Could not read ABS parameters"
                         return 0
                     return module_bits
                 def write_device(self):
                     """
                     This function sends the beams list to every abs module.
+                    It needs 'module_conf' function
                     """
-                    beams_list    = ast.literal_eval(self.beams)
+                    ###beams_list    = ast.literal_eval(self.beams)
-                    beams = []
+                    ###beams = []
+                    beams = ABSBeam.objects.filter(abs_conf=self)
-                    for bl in range(1,len(beams_list)+1):
+                    ###for bl in range(1,len(beams_list)+1):
-                        b = ABSBeam.objects.get(pk=beams_list['beam'+str(bl)])
+                    ###    b = ABSBeam.objects.get(pk=beams_list['beam'+str(bl)])
-                        beams.append(b)
+                    ###    beams.append(b)
                     #---Write each abs module---
+                    if beams:
                         beams_status = ast.literal_eval(self.module_status)
-                    for i in range(62,65):
+                        for i in range(62,65): #(62,65)
                             try:
-                            self.module_conf(i, beams)
+                                answer = self.module_conf(i, beams)
                                 beams_status[str(i)] = 1
                                 self.module_status = json.dumps(beams_status)
                                 self.save()
                             #self.module_conf(63,beams)
                             #beams_status[str(63)] = 1
                             #self.module_status = json.dumps(beams_status)
                             except:
                                 beams_status[str(i)] = 0
                                 self.module_status = json.dumps(beams_status)
                                 self.save()
-                            #return 0
+                                answer = 0
+                                return 0
+                    else:
+                        self.message = "ABS Configuration does not have beams"
+                        return 0
                     #self.device.status = 1
+                    ##
+                    if answer==1:
+                        self.message = "ABS Beams List have been sent to ABS Modules"
+                    else:
+                        self.message = "Could not read ABS parameters"
+                    ##
                     self.save()
                     return 1
                 def write_module(self, module):
                     """
                     Send configuration to one abs module
                     """
                     parameters = {}
                     ip_address  = self.abs_conf.device.ip_address
                     ip_address  = ip_address.split('.')
                     module_seq  = (ip_address[0],ip_address[1],ip_address[2])
                     dot         = '.'
                     module_ip   = dot.join(module_seq)+'.'+str(module)
                     module_port = self.abs_conf.device.port_address
                     write_route = 'http://'+module_ip+':'+str(module_port)+'/configure'
                     #print write_route
                     header = 'JROABSCeCnModCnMod01000108SNDFexperimento1.ab1'
                     module = 'ABS_'+str(module)
                     beams  = {1: '001000', 2: '010001', 3: '010010', 4: '000011', 5: '101100', 6: '101101',
 : '110110', 8: '111111', 9: '000000', 10: '001001', 11: '010010', 12: '011011'}
                     parameters['header'] = header
                     parameters['module'] = module
                     parameters['beams']  = json.dumps(beams)
                     answer = ''
                     try:
                         r_write = requests.post(write_route, parameters, timeout=0.5)
                         answer  = r_write.json()
                         self.message = answer['message']
                     except:
                         self.message = "Could not write ABS parameters"
                         return 0
                     #self.device.status = int(answer['status'])
                     return 1
                 def beam_selector(self, module, beam_pos):
                     """
                     This function selects the beam number for one absmodule.
                     """
                     if beam_pos > 0:
                         beam_pos = beam_pos - 1
                     else:
                         beam_pos = 0
                     #El indice del apunte debe ser menor que el numero total de apuntes
                     #El servidor tcp en el embebido comienza a contar desde 0
                     beams_list    = ast.literal_eval(self.beams)
                     if len(beams_list) < beam_pos:
                         return 0
                     flag = 1
                     if beam_pos>9:
                         flag = 2
                     module_address = ('192.168.1.'+str(module), 5500)
                     header   = 'JROABSCeCnModCnMod0100000'
                     numbers  = len(str(beam_pos))
                     function = 'CHGB'
                     message_tx = header+str(numbers)+function+str(beam_pos)+'0'
                     # Create the datagram socket
                     sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                     #sock.connect(module_address)
                     try:
                         sock.connect(module_address)
                         sock.send(message_tx)
                         sock.close()
                         print("Writing abs module:"+module_address[0]+"...")
                     except:
                         sock = None
                         print("Problem writing abs module:"+module_address[0])
                         return 0
                     return 1
                 def change_beam(self, beam_pos):
                     """
                     This function selects the beam number for all absmodules.
                     """
                     for i in range(1,65):
                         try:
                             self.beam_selector(i,beam_pos)
                         except:
                             print("Problem with module: 192.168.1."+str(i))
                             self.message = "Problem with module: 192.168.1."+str(i)
                             #return 0
                     return 1
                 def send_beam_num(self, beam_pos):
                     """
                     This function connects to a multicast group and sends the beam number
                     to all abs modules.
                     """
                     if beam_pos > 0:
                         beam_pos = beam_pos - 1
                     else:
                         beam_pos = 0
                     #El indice del apunte debe ser menor que el numero total de apuntes
                     #El servidor tcp en el embebido comienza a contar desde 0
                     beams_list    = ast.literal_eval(self.beams)
                     if len(beams_list) < beam_pos:
                         return 0
                     flag = 1
                     if beam_pos>9:
                         flag = 2
                     header   = 'JROABSCeCnModCnMod0100000'
                     flag  = str(flag)
                     function = 'CHGB'
                     message_tx = header+flag+function+str(beam_pos)+'0'
                     multicast_group = '224.3.29.71'
                     server_address = ('',10000)
                     # Create the socket
                     sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
                     # Bind to the server address
                     sock.bind(server_address)
                     # Telling the OS add the socket to the multicast on all interfaces
                     group = socket.inet_aton(multicast_group)
                     mreq  = struct.pack('4sL', group, socket.INADDR_ANY)
                     sock.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq)
                     #print 'sending acknowledgement to all: \n' + message_tx
                     sock.sendto(message_tx, (multicast_group, 10000))
                     sock.close()
                     sock = None
                     return 1
                 def test1(self):
                     t1 = time.time()
                     t2 = 0
-                    while (t2-t1)<300:
+                    while (t2-t1)<100:#300
                         t2 = time.time()
-                        self.send_beam_num(1)
-                        time.sleep(0.04)
                         self.send_beam_num(2)
                         time.sleep(0.04)
+                        self.send_beam_num(1)
+                        time.sleep(0.04)
                     return
                 def change_procs_test1(self, module):
-                	for i in range (1,300):
+                	for i in range (1,300):#300
-                	    beam_pos = 0
+                	    beam_pos = 1
                 	    module_address = ('192.168.1.'+str(module), 5500)
                 	    header   = 'JROABSCeCnModCnMod0100000'
                 	    numbers  = len(str(beam_pos))
                 	    function = 'CHGB'
                 	    message_tx = header+str(numbers)+function+str(beam_pos)+'0'
                 	    # Create the datagram socket
                 	    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                 	    sock.connect(module_address)
                 	    sock.send(message_tx)
                 	    #t = sock.recv(1024)
                 	    sock.close()
                 	    sock = None
-                	    time.sleep(0.2)
+                	    time.sleep(0.04)
-                	    beam_pos = 1
+                	    beam_pos = 0
                 	    numbers  = len(str(beam_pos))
                 	    message_tx = header+str(numbers)+function+str(beam_pos)+'0'
                 	    # Create the datagram socket
                 	    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                 	    sock.connect(module_address)
                 	    sock.send(message_tx)
                 	    sock.close()
                 	    sock = None
-                	    time.sleep(0.2)
+                	    time.sleep(0.04)
                 def multi_procs_test1(self):
+                    """
+                    This function sends the beam number to all abs modules using multiprocessing.
+                    """
                     #if __name__ == "__main__":
                     size = 10000000   # Number of random numbers to add
-                    procs =  65 # (Number-1) of processes to create
+                    procs =  65 # (Number-1) of processes to create (absmodule)
                     # Create a list of jobs and then iterate through
                     # the number of processes appending each process to
                     # the job list
                     jobs = []
-                    for i in range(62, procs):
+                    for i in range(1, procs):
                         process = multiprocessing.Process(target=self.change_procs_test1,args=(i,))
                         jobs.append(process)
                         #print jobs
                         # Start the processes (i.e. calculate the random number lists)
                     for j in jobs:
                             #time.sleep(0.4)
                             #print j
                             j.start()
                         # Ensure all of the processes have finished
                     for j in jobs:
                             j.join()
                     print("List processing complete.")
                     return 1
+                def multi_procs_test2(self):
+                    """
+                    This function use multiprocessing python library. Importing Pool we can select
+                    the number of cores we want to use
+                    After 'nproc' linux command, we know how many cores computer has.
+                    NOT WORKING
+                    """
+                    import multiprocessing
+                    pool = multiprocessing.Pool(3) # cores
+                    tasks = []
+                    procs = 65
+                    for i in range(62, procs):
+                        tasks.append( (i,))
+                    #print tasks
+                    #pool.apply_async(self.change_procs_test1, 62)
+                    results = [pool.apply( self.change_procs_test1, t ) for t in tasks]
+                    #for result in results:
+                        #result.get()
+                        #(plotNum, plotFilename) = result.get()
+                        #print("Result: plot %d written to %s" % (plotNum, plotFilename) )
+                    return 1
+                def multi_procs_test3(self):
+                    """
+                    This function use multiprocessing python library. Importing Pool we can select
+                    the number of cores we want to use
+                    After 'nproc' linux command, we know how many cores computer has.
+                    """
+                    from multiprocessing import Pool
+                    import time
+                    def f(x):
+                        return x*x
+                    tasks = []
+                    procs = 65
+                    pool = Pool(processes=4)
+                    #for i in range(62, procs):
+                    #result = pool.map(f, range(62,65))
+                    it = pool.imap(self.change_procs_test1, range(62,65))
+                    #result.get(timeout=5)
+                    return 1
+                def f(x):
+                    print x
+                    return
+                def multi_procs_test4(self):
+                    import multiprocessing as mp
+                    num_workers = mp.cpu_count()
+                    pool = mp.Pool(num_workers)
+                    procs = 65
+                    for i in range(62, procs):
+                    #for task in tasks:
+                        pool.apply_async(self.f, args = (i,))
+                    pool.close()
+                    pool.join()
+                    return 1
                 def status_device(self):
                     return 1
             class ABSBeam(models.Model):
                 name         = models.CharField(max_length=60, default='Beam')
                 antenna      = models.CharField(verbose_name='Antenna', max_length=1000, default=antenna_default)
                 abs_conf     = models.ForeignKey(ABSConfiguration, null=True, verbose_name='ABS Configuration')
                 tx           = models.CharField(verbose_name='Tx', max_length=1000, default=tx_default)
                 rx           = models.CharField(verbose_name='Rx', max_length=1000, default=rx_default)
                 s_time       = models.TimeField(verbose_name='Star Time', default='00:00:00')
                 e_time       = models.TimeField(verbose_name='End Time', default='23:59:59')
                 modules_conf = models.CharField(verbose_name='Modules', max_length=2000, default=json.dumps(conf_default))
                 ues          = models.CharField(verbose_name='Ues', max_length=100, default=ues_default)
                 only_rx      = models.CharField(verbose_name='Only RX', max_length=40, default=onlyrx_default)
                 class Meta:
                     db_table = 'abs_beams'
                 def __unicode__(self):
                     return u'%s' % (self.name)
                 def parms_to_dict(self):
                     #Update data
                     self.modules_6bits()
                     parameters = {}
                     parameters['name']          = self.name
                     parameters['antenna']       = ast.literal_eval(self.antenna)
                     parameters['abs_conf']      = self.abs_conf.name
                     parameters['tx']            = ast.literal_eval(self.tx)
                     parameters['rx']            = ast.literal_eval(self.rx)
                     parameters['s_time']        = self.s_time.strftime("%H:%M:%S")
                     parameters['e_time']        = self.e_time.strftime("%H:%M:%S")
                     parameters['configuration'] = ast.literal_eval(self.modules_conf)
                     parameters['ues']           = ast.literal_eval(self.ues)
                     parameters['only_rx']       = json.loads(self.only_rx)
                     return parameters
                 def dict_to_parms(self, parameters):
                     self.name     = parameters['name']
                     self.antenna  = json.dumps(parameters['antenna'])
                     #self.abs_conf = parameters['abs_conf']
                     self.tx       = json.dumps(parameters['tx'])
                     self.rx       = json.dumps(parameters['rx'])
                     #parameters['s_time']
                     #parameters['e_time']
                     self.ues      = json.dumps(parameters['ues'])
                     self.only_rx     = json.dumps(parameters['only_rx'])
                     self.modules_6bits()
                     self.save()
                     return parameters
+                def clone(self, **kwargs):
+                    self.pk = None
+                    self.id = None
+                    for attr, value in kwargs.items():
+                        setattr(self, attr, value)
+                    self.save()
+                    return self
                 def change_beam(self, beam_pos=0):
                     module_63 = ('192.168.1.63', 5500)
                     header   = 'JROABSCeCnModCnMod0100000'
                     numbers  = len(str(beam_pos))
                     function = 'CHGB'
                     message_tx = header+str(numbers)+function+str(beam_pos)+'0'
                     # Create the datagram socket
                     sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                     sock.connect(module_63)
                     sock.send(message_tx)
                     sock.close()
                     return message_tx
                 def change_module_beam(self, module=61,beam_pos=0):
                     module_address = ('192.168.1.'+str(module), 5500)
                     header   = 'JROABSCeCnModCnMod0100000'
                     numbers  = len(str(beam_pos))
                     function = 'CHGB'
                     message_tx = header+str(numbers)+function+str(beam_pos)+'0'
                     # Create the datagram socket
                     try:
                         sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                         sock.connect(module_address)
                         sock.send(message_tx)
                         sock.close()
                     except:
                         return 0
                     return message_tx
                 def write_device(self):
                     parameters = {}
                     module_ip   = '192.168.1.63'
                     write_route = 'http://192.168.1.63:8080/configure'
                     header = 'JROABSCeCnModCnMod01000108SNDFexperimento1.ab1'
                     module = 'ABS_63'
                     beams  = {1: '001000', 2: '010001', 3: '010010', 4: '000011', 5: '101100', 6: '101101',
 : '110110', 8: '111111', 9: '000000', 10: '001001', 11: '010010', 12: '011011'}
                     parameters['header'] = header
                     parameters['module'] = module
                     parameters['beams']  = json.dumps(beams)
                     answer = ''
                     try:
                         r_write = requests.post(write_route, parameters, timeout=0.5)
                         answer  = r_write.json()
                         self.message = answer['message']
                     except:
                         self.message = "Could not write ABS parameters"
                         return 0
                     #self.device.status = int(answer['status'])
                     return 1
                 def module_6bits(self, module):
                     """
                     This function reads antenna pattern and choose 6bits (upbits-downbits) for one abs module
                     """
                     if module > 64:
                         beam_bits = ""
                         return beam_bits
                     data      = ast.literal_eval(self.antenna)
                     up_data   = data['antenna_up']
                     down_data = data['antenna_down']
                     pos        = ip2position(module)
                     up_value   = up_data[pos[0]][pos[1]]
                     down_value = down_data[pos[0]][pos[1]]
                     up_bits   = up_conv_bits(up_value)
                     down_bits = down_conv_bits(down_value)
                     beam_bits = up_bits+down_bits
                     return beam_bits
                 def modules_6bits(self):
                     """
                     This function returns 6bits from every abs module (1-64) in a dict
                     """
                     modules_configuration = ast.literal_eval(self.modules_conf)
                     for i in range(1,65):
                         modules_configuration[str(i)] =  self.module_6bits(i)
                     self.modules_conf = json.dumps(modules_configuration)
                     self.save()
                     return self.modules_conf
                 def add_beam2list(self):
                     """
                     This function adds a beam to the beams list of ABS Configuration.
                     """
                     beams = ast.literal_eval(self.abs_conf.beams)
                     if any(beams):
                         for beam in beams:
                             if beams[beam] == self.id:
                                 return
                         i = len(beams)+1
                         beams['beam'+str(i)] = self.id
                     else:
                         beams['beam1'] = self.id
                     self.abs_conf.beams = json.dumps(beams)
                     self.abs_conf.save()
                     return
                 def remove_beamfromlist(self):
                     """
                     This function removes current beam from the beams list of ABS Configuration.
                     """
                     beams = ast.literal_eval(self.abs_conf.beams)
                     dict_position = ''
                     if any(beams):
                         for beam in beams:
                             if beams[beam] == self.id:
                                 dict_position = beam
                         if dict_position != '':
                             beams.pop(str(dict_position),None)
                     else:
                         return
                     self.abs_conf.beams = json.dumps(beams)
                     self.abs_conf.save()
                     return
                 @property
                 def get_upvalues(self):
                     """
                     This function reads antenna pattern and show the up-value of one abs module
                     """
                     data      = ast.literal_eval(self.antenna)
                     up_data   = data['antenna_up']
                     up_values = []
                     for data in up_data:
                         for i in range(0,8):
                             up_values.append(data[i])
                     return up_values
                 @property
                 def antenna_upvalues(self):
                     """
                     This function reads antenna pattern and show the up - values of one abs beam
                     in a particular order
                     """
                     data      = ast.literal_eval(self.antenna)
                     up_data   = data['antenna_up']
                     return up_data
                 @property
                 def antenna_downvalues(self):
                     """
                     This function reads antenna pattern and show the down - values of one abs beam
                     in a particular order
                     """
                     data      = ast.literal_eval(self.antenna)
                     down_data   = data['antenna_down']
                     return down_data
                 @property
                 def get_downvalues(self):
                     """
                     This function reads antenna pattern and show the down-value of one abs module
                     """
                     data      = ast.literal_eval(self.antenna)
                     down_data = data['antenna_down']
                     down_values = []
                     for data in down_data:
                         for i in range(0,8):
                             down_values.append(data[i])
                     return down_values
                 @property
                 def get_up_ues(self):
                     """
                     This function shows the up-ues-value of one beam
                     """
                     data      = ast.literal_eval(self.ues)
                     up_ues = data['up']
                     return up_ues
                 @property
                 def get_down_ues(self):
                     """
                     This function shows the down-ues-value of one beam
                     """
                     data      = ast.literal_eval(self.ues)
                     down_ues = data['down']
                     return down_ues
                 @property
                 def get_up_onlyrx(self):
                     """
                     This function shows the up-onlyrx-value of one beam
                     """
                     data      = json.loads(self.only_rx)
                     up_onlyrx = data['up']
                     return up_onlyrx
                 @property
                 def get_down_onlyrx(self):
                     """
                     This function shows the down-onlyrx-value of one beam
                     """
                     data      = json.loads(self.only_rx)
                     down_onlyrx = data['down']
                     return down_onlyrx
                 @property
                 def get_tx(self):
                     """
                     This function shows the tx-values of one beam
                     """
                     data = json.loads(self.tx)
                     return data
                 @property
                 def get_uptx(self):
                     """
                     This function shows the up-tx-values of one beam
                     """
                     data = json.loads(self.tx)
                     up_data = data['up']
                     up_values = []
                     for data in up_data:
                         for i in range(0,8):
                             up_values.append(data[i])
                     return up_values
                 @property
                 def get_downtx(self):
                     """
                     This function shows the down-tx-values of one beam
                     """
                     data = json.loads(self.tx)
                     down_data = data['down']
                     down_values = []
                     for data in down_data:
                         for i in range(0,8):
                             down_values.append(data[i])
                     return down_values
                 @property
                 def get_rx(self):
                     """
                     This function shows the rx-values of one beam
                     """
                     data = json.loads(self.rx)
                     return data
                 @property
                 def get_uprx(self):
                     """
                     This function shows the up-rx-values of one beam
                     """
                     data = json.loads(self.rx)
                     up_data = data['up']
                     up_values = []
                     for data in up_data:
                         for i in range(0,8):
                             up_values.append(data[i])
                     return up_values
                 @property
                 def get_downrx(self):
                     """
                     This function shows the down-rx-values of one beam
                     """
                     data = json.loads(self.rx)
                     down_data = data['down']
                     down_values = []
                     for data in down_data:
                         for i in range(0,8):
                             down_values.append(data[i])
                     return down_values

apps/abs/templates/abs_conf.html +2 -2

             {% extends "dev_conf.html" %}
             {% block extra-menu-actions %}
             <li><a href="{{ dev_conf.get_absolute_url_plot }}" target="_blank"><span class="glyphicon glyphicon-picture" aria-hidden="true"></span> View Patterns </a></li>
-            <li><a href="{{ dev_conf.get_absolute_url_write }}"><span class="glyphicon glyphicon-download" aria-hidden="true"></span> Write</a></li>
+            <!--<li><a href="{{ dev_conf.get_absolute_url_write }}"><span class="glyphicon glyphicon-download" aria-hidden="true"></span> Write</a></li>-->
             {% endblock %}
             {% block extra-content %}
             <style>
             .abs {
                 border: 2px solid #00334d;
                 vertical-align: center;
                 display: inline-block;
             }
             .abs tr:nth-child(1){
                 border-bottom: 1px dashed #00334d;
             }
             .abs tr{
                 border-bottom: 0px solid #00334d;
             }
             .abs td {
                 border-right: 1px dashed #00334d;
                 text-align: center;
                 padding: 5px;
             }
             .legend {
                 margin-left: 15px;
                 display: inline-block;
                 border: 2px solid #00334d;
                 vertical-align: top;
             }
             .legend th{
                 border-bottom: 1px dashed #00334d;
                 font-weight: bold;
                 vertical-align: center;
                 text-align: center;
             }
             .legend td {
                 padding: 2px;
                 text-align: center;
             }
             .north {
                 border: 2px solid #00334d;
                 vertical-align: center;
                 font-weight: bold;
             }
             .north tr{
                 border: 1px solid #ffffff;
                 background-color: #FF0000;
             }
             .north td{
                 border: 2px solid #e2e2e7;
                 text-align: center;
                 padding: 1px 15px 1px 15px;
             }
             .north tr:nth-child(even) td:nth-child(n){
                 border-bottom: 12px solid #e2e2e7;
             }
             .north td:nth-child(n) {
                 border-right: 12px solid #e2e2e7;
             }
             .north td:nth-last-child(4n+1) {
                 border-right:  2px solid #e2e2e7;
             }
             .north tr:nth-last-child(1) td:nth-child(n){
                 border-bottom: 3px solid #e2e2e7;
             }
             .north tr:nth-child(2) td:nth-child(2){
                 background-color: #00cc00;
             }
             .north tr:nth-child(2) td:nth-child(4){
                 background-color: #ee902c;
             }
             .east {
                 border: 2px solid #00334d;
                 vertical-align: center;
                 font-weight: bold;
             }
             .east tr{
                 border: 1px solid #ffffff;
                 background-color: #FF0000;
             }
             .east td{
                 border: 2px solid #e2e2e7;
                 text-align: center;
                 padding: 1px 15px 1px 15px;
             }
             .east tr:nth-child(even) td:nth-child(n){
                 border-bottom: 12px solid #e2e2e7;
             }
             .east td:nth-child(n) {
                 border-right: 12px solid #e2e2e7;
             }
             .east td:nth-last-child(4n+1) {
                 border-right:  2px solid #e2e2e7;
             }
             .east tr:nth-last-child(1) td:nth-child(n){
                 border-bottom: 3px solid #e2e2e7;
             }
             .east tr:nth-child(2) td:nth-child(2){
                 background-color: #00cc00;
             }
             .east tr:nth-child(2) td:nth-child(4){
                 background-color: #ee902c;
             }
             .west {
                 border: 2px solid #00334d;
                 vertical-align: center;
                 font-weight: bold;
             }
             .west tr{
                 border: 1px solid #ffffff;
                 background-color: #FF0000;
             }
             .west td{
                 border: 2px solid #e2e2e7;
                 text-align: center;
                 padding: 1px 15px 1px 15px;
             }
             .west tr:nth-child(even) td:nth-child(n){
                 border-bottom: 12px solid #e2e2e7;
             }
             .west td:nth-child(n) {
                 border-right: 12px solid #e2e2e7;
             }
             .west td:nth-last-child(4n+1) {
                 border-right:  2px solid #e2e2e7;
             }
             .west tr:nth-last-child(1) td:nth-child(n){
                 border-bottom: 3px solid #e2e2e7;
             }
             .west tr:nth-child(2) td:nth-child(2){
                 background-color: #00cc00;
             }
             .west tr:nth-child(2) td:nth-child(4){
                 background-color: #ee902c;
             }
             .south {
                 border: 2px solid #00334d;
                 vertical-align: center;
                 font-weight: bold;
             }
             .south tr{
                 border: 1px solid #ffffff;
                 background-color: #FF0000;
             }
             .south td{
                 border: 2px solid #e2e2e7;
                 text-align: center;
                 padding: 1px 15px 1px 15px;
             }
             .south tr:nth-child(even) td:nth-child(n){
                 border-bottom: 12px solid #e2e2e7;
             }
             .south td:nth-child(n) {
                 border-right: 12px solid #e2e2e7;
             }
             .south td:nth-last-child(4n+1) {
                 border-right:  2px solid #e2e2e7;
             }
             .south tr:nth-last-child(1) td:nth-child(n){
                 border-bottom: 3px solid #e2e2e7;
             }
             .south tr:nth-child(2) td:nth-child(2){
                 background-color: #00cc00;
             }
             .south tr:nth-child(2) td:nth-child(4){
                 background-color: #ee902c;
             }
             </style>
             <h4>Beams:</h4>
-            {% if beams_id %}
+            {% if beams %}
             <div class="container">
               <ul class="nav nav-pills">
               {% for beam in beams %}
               <li {% if forloop.counter == 1 %} class="active" {% endif %}>
                 <a data-toggle="pill" id="button-{{ forloop.counter }}" href="#">{{ forloop.counter }}</a>
               </li>
               {% endfor %}
               </ul>
             </div>
             <script>
             $(document).ready(function() {
               {% for beam in beams %}
                 $( "#button-{{ forloop.counter }}" ).click(function() {
                   //$(this).addClass('active');
                   var beam_upvalues   = {{beam.get_upvalues}};
                   var beam_downvalues = {{beam.get_downvalues}};
                   //alert(beam_upvalues)
                   var table = document.getElementById('abs_pattern');
                   var cells = table.getElementsByTagName('td');
                   //alert(cells[99].textContent);
                   for (var i = 1, len = 30; i < len; i++) {
                       if ((i > 24) && (i<29)){
                         cells[i].innerHTML = beam_upvalues[i-1].toFixed(1);
                         cells[i+4].innerHTML = beam_downvalues[i-1].toFixed(1);
                         }
                       else if ((i > 16) && (i<21)){
                         cells[i].innerHTML = beam_upvalues[i-1].toFixed(1);
                         cells[i+4].innerHTML = beam_downvalues[i-1].toFixed(1);
                         }
                       else if ((i > 8) && (i<13)){
                         cells[i].innerHTML = beam_upvalues[i-1].toFixed(1);
                         cells[i+4].innerHTML = beam_downvalues[i-1].toFixed(1);
                         }
                       else if (i < 5) {
                         cells[i].innerHTML = beam_upvalues[i-1].toFixed(1);
                         cells[i+4].innerHTML = beam_downvalues[i-1].toFixed(1);
                         }
                     }
                     for (var i = 34, len = 63; i < len; i++) {
                       if ((i > 57) && (i<62)) {
                         cells[i].innerHTML = beam_upvalues[i-30].toFixed(1);
                         cells[i+4].innerHTML = beam_downvalues[i-30].toFixed(1);
                         }
                       if ((i > 49) && (i<54)) {
                         cells[i].innerHTML = beam_upvalues[i-30].toFixed(1);
                         cells[i+4].innerHTML = beam_downvalues[i-30].toFixed(1);
                         }
                       else if ((i > 41) && (i<46)) {
                         cells[i].innerHTML = beam_upvalues[i-30].toFixed(1);
                         cells[i+4].innerHTML = beam_downvalues[i-30].toFixed(1);
                         }
                       else if (i < 38) {
                         cells[i].innerHTML = beam_upvalues[i-30].toFixed(1);
                         cells[i+4].innerHTML = beam_downvalues[i-30].toFixed(1);
                         }
                     }
                     for (var i = 67, len = 96; i < len; i++) {
                       if ((i > 90) && (i<95)) {
                         cells[i].innerHTML = beam_upvalues[i-35].toFixed(1);
                         cells[i+4].innerHTML = beam_downvalues[i-35].toFixed(1);
                         }
                       else if ((i > 82) && (i<87)) {
                         cells[i].innerHTML = beam_upvalues[i-35].toFixed(1);
                         cells[i+4].innerHTML = beam_downvalues[i-35].toFixed(1);
                         }
                       else if ((i > 74) && (i<79)) {
                         cells[i].innerHTML = beam_upvalues[i-35].toFixed(1);
                         cells[i+4].innerHTML = beam_downvalues[i-35].toFixed(1);
                         }
                       else if (i < 71) {
                         cells[i].innerHTML = beam_upvalues[i-35].toFixed(1);
                         cells[i+4].innerHTML = beam_downvalues[i-35].toFixed(1);
                         }
                     }
                     for (var i = 100, len = 129; i < len; i++) {
                       if ((i > 123) && (i<128)) {
                         cells[i].innerHTML = beam_upvalues[i-64].toFixed(1);
                         cells[i+4].innerHTML = beam_downvalues[i-64].toFixed(1);
                         }
                       else if ((i > 115) && (i<120)) {
                         cells[i].innerHTML = beam_upvalues[i-64].toFixed(1);
                         cells[i+4].innerHTML = beam_downvalues[i-64].toFixed(1);
                         }
                       else if ((i > 107) && (i<112)) {
                         cells[i].innerHTML = beam_upvalues[i-64].toFixed(1);
                         cells[i+4].innerHTML = beam_downvalues[i-64].toFixed(1);
                         }
                       else if (i < 104) {
                         cells[i].innerHTML = beam_upvalues[i-64].toFixed(1);
                         cells[i+4].innerHTML = beam_downvalues[i-64].toFixed(1);
                         }
                     }
                     //$('#button-1').addClass("active");
                   });
               {% endfor %}
             //})
             //function ChangeColor() {
             //    document.getElementById("button_1").style.backgroundColor = "#2c3e50";
             //    document.getElementById("button_1").style.color = "#ecf0f1";
             //}
             });
             </script>
             <br>
             <table id="abs_pattern" class="abs">
               <tr>
                 <td> <b>North Quarter</b>
                   <table class="north ">
                     <tr>
                       <td>{{beams.0.get_upvalues.0}}</td> <td>{{beams.0.get_upvalues.1}}</td> <td>{{beams.0.get_upvalues.2}}</td> <td>{{beams.0.get_upvalues.3}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_downvalues.0}}</td> <td>{{beams.0.get_downvalues.1}}</td> <td>{{beams.0.get_downvalues.2}}</td> <td>{{beams.0.get_downvalues.3}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_upvalues.8}}</td> <td>{{beams.0.get_upvalues.9}}</td> <td>{{beams.0.get_upvalues.10}}</td> <td>{{beams.0.get_upvalues.11}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_downvalues.8}}</td> <td>{{beams.0.get_downvalues.9}}</td> <td>{{beams.0.get_downvalues.10}}</td> <td>{{beams.0.get_downvalues.11}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_upvalues.16}}</td> <td>{{beams.0.get_upvalues.17}}</td> <td>{{beams.0.get_upvalues.18}}</td> <td>{{beams.0.get_upvalues.19}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_downvalues.16}}</td> <td>{{beams.0.get_downvalues.17}}</td> <td>{{beams.0.get_downvalues.18}}</td> <td>{{beams.0.get_downvalues.19}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_upvalues.24}}</td> <td>{{beams.0.get_upvalues.25}}</td> <td>{{beams.0.get_upvalues.26}}</td> <td>{{beams.0.get_upvalues.27}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_downvalues.24}}</td> <td>{{beams.0.get_downvalues.25}}</td> <td>{{beams.0.get_downvalues.26}}</td> <td>{{beams.0.get_downvalues.27}}</td>
                     </tr>
                   </table>
                 </td>
                 <td> <b>East Quarter</b>
                   <table class="east ">
                     <tr>
                       <td>{{beams.0.get_upvalues.4}}</td> <td>{{beams.0.get_upvalues.5}}</td> <td>{{beams.0.get_upvalues.6}}</td> <td>{{beams.0.get_upvalues.7}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_downvalues.4}}</td> <td>{{beams.0.get_downvalues.5}}</td> <td>{{beams.0.get_downvalues.6}}</td> <td>{{beams.0.get_downvalues.7}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_upvalues.12}}</td> <td>{{beams.0.get_upvalues.13}}</td> <td>{{beams.0.get_upvalues.14}}</td> <td>{{beams.0.get_upvalues.15}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_downvalues.12}}</td> <td>{{beams.0.get_downvalues.13}}</td> <td>{{beams.0.get_downvalues.14}}</td> <td>{{beams.0.get_downvalues.15}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_upvalues.20}}</td> <td>{{beams.0.get_upvalues.21}}</td> <td>{{beams.0.get_upvalues.22}}</td> <td>{{beams.0.get_upvalues.23}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_downvalues.20}}</td> <td>{{beams.0.get_downvalues.21}}</td> <td>{{beams.0.get_downvalues.22}}</td> <td>{{beams.0.get_downvalues.23}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_upvalues.28}}</td> <td>{{beams.0.get_upvalues.29}}</td> <td>{{beams.0.get_upvalues.30}}</td> <td>{{beams.0.get_upvalues.31}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_downvalues.28}}</td> <td>{{beams.0.get_downvalues.29}}</td> <td>{{beams.0.get_downvalues.30}}</td> <td>{{beams.0.get_downvalues.31}}</td>
                     </tr>
                   </table>
                 </td>
               </tr>
                 <tr>
                 <td> <b>West Quarter</b>
                   <table class="west ">
                     <tr>
                       <td>{{beams.0.get_upvalues.32}}</td> <td>{{beams.0.get_upvalues.33}}</td> <td>{{beams.0.get_upvalues.34}}</td> <td>{{beams.0.get_upvalues.35}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_downvalues.32}}</td> <td>{{beams.0.get_downvalues.33}}</td> <td>{{beams.0.get_downvalues.34}}</td> <td>{{beams.0.get_downvalues.35}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_upvalues.40}}</td> <td>{{beams.0.get_upvalues.41}}</td> <td>{{beams.0.get_upvalues.42}}</td> <td>{{beams.0.get_upvalues.43}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_downvalues.40}}</td> <td>{{beams.0.get_downvalues.41}}</td> <td>{{beams.0.get_downvalues.42}}</td> <td>{{beams.0.get_downvalues.43}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_upvalues.48}}</td> <td>{{beams.0.get_upvalues.49}}</td> <td>{{beams.0.get_upvalues.50}}</td> <td>{{beams.0.get_upvalues.51}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_downvalues.48}}</td> <td>{{beams.0.get_downvalues.49}}</td> <td>{{beams.0.get_downvalues.50}}</td> <td>{{beams.0.get_downvalues.51}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_upvalues.56}}</td> <td>{{beams.0.get_upvalues.57}}</td> <td>{{beams.0.get_upvalues.58}}</td> <td>{{beams.0.get_upvalues.59}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_downvalues.56}}</td> <td>{{beams.0.get_downvalues.57}}</td> <td>{{beams.0.get_downvalues.58}}</td> <td>{{beams.0.get_downvalues.59}}</td>
                     </tr>
                   </table>
                 </td>
                 <td> <b>South Quarter</b>
                   <table class="south ">
                     <tr>
                       <td>{{beams.0.get_upvalues.36}}</td> <td>{{beams.0.get_upvalues.37}}</td> <td>{{beams.0.get_upvalues.38}}</td> <td>{{beams.0.get_upvalues.39}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_downvalues.36}}</td> <td>{{beams.0.get_downvalues.37}}</td> <td>{{beams.0.get_downvalues.38}}</td> <td>{{beams.0.get_downvalues.39}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_upvalues.44}}</td> <td>{{beams.0.get_upvalues.45}}</td> <td>{{beams.0.get_upvalues.46}}</td> <td>{{beams.0.get_upvalues.47}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_downvalues.44}}</td> <td>{{beams.0.get_downvalues.45}}</td> <td>{{beams.0.get_downvalues.46}}</td> <td>{{beams.0.get_downvalues.47}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_upvalues.52}}</td> <td>{{beams.0.get_upvalues.53}}</td> <td>{{beams.0.get_upvalues.54}}</td> <td>{{beams.0.get_upvalues.55}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_downvalues.52}}</td> <td>{{beams.0.get_downvalues.53}}</td> <td>{{beams.0.get_downvalues.54}}</td> <td>{{beams.0.get_downvalues.55}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_upvalues.60}}</td> <td>{{beams.0.get_upvalues.61}}</td> <td>{{beams.0.get_upvalues.62}}</td> <td>{{beams.0.get_upvalues.63}}</td>
                     </tr>
                     <tr>
                       <td>{{beams.0.get_downvalues.60}}</td> <td>{{beams.0.get_downvalues.61}}</td> <td>{{beams.0.get_downvalues.62}}</td> <td>{{beams.0.get_downvalues.63}}</td>
                     </tr>
                   </table>
                 </td>
               </tr>
             </table>
             <table class="legend">
               <tr>
                 <th colspan="2">Legend</th>
               </tr>
               <tr>
                 <td style="color:#ff0000;"><i>RED</i></td><td>Disconnected</td>
               </tr>
               <tr>
                 <td style="color:#ee902c;"><i>ORANGE</i></td><td>Connected</td>
               </tr>
               <tr>
                 <td style="color:#00cc00;"><i>GREEN</i></td><td>Running</td>
               </tr>
             </table>
             {% else %}
               <p style="color:#b4bcc2; margin-left: 5%;"><i>No Beams...</i></p>
             {% endif %}
             {% endblock %}

apps/abs/views.py +18 -15

             from django.shortcuts import render_to_response
             from django.template import RequestContext
             from django.shortcuts import redirect, render, get_object_or_404
             from django.contrib import messages
             from django.conf import settings
             from django.http import HttpResponse
             from datetime import datetime
             from time import sleep
             import os
             from apps.main.models import Device, Configuration
             from apps.main.views import sidebar
             from .models import ABSConfiguration, ABSBeam
             from .forms import ABSConfigurationForm, ABSBeamEditForm, ABSBeamAddForm
             from .utils.overJroShow import overJroShow
             from .utils.OverJRO import OverJRO
             # Create your views here.
             import json, ast
             def get_values_from_form(form_data):
                 sublistup     = []
                 sublistdown   = []
                 subtxlistup   = []
                 subtxlistdown = []
                 subrxlistup   = []
                 subrxlistdown = []
                 up_values_list     = []
                 down_values_list   = []
                 up_txvalues_list   = []
                 down_txvalues_list = []
                 up_rxvalues_list   = []
                 down_rxvalues_list = []
                 values_list = {}
                 cont = 1
                 for i in range(1,65):
                     x = float(form_data['abs_up'+str(i)])
                     y = float(form_data['abs_down'+str(i)])
                     sublistup.append(x)
                     sublistdown.append(y)
                     if str(i) in form_data.getlist('uptx_checks'):
                         subtxlistup.append(1)
                     else:
                         subtxlistup.append(0)
                     if str(i) in form_data.getlist('downtx_checks'):
                         subtxlistdown.append(1)
                     else:
                         subtxlistdown.append(0)
                     if str(i) in form_data.getlist('uprx_checks'):
                         subrxlistup.append(1)
                     else:
                         subrxlistup.append(0)
                     if str(i) in form_data.getlist('downrx_checks'):
                         subrxlistdown.append(1)
                     else:
                         subrxlistdown.append(0)
                     cont = cont+1
                     if cont == 9:
                         up_values_list.append(sublistup)
                         down_values_list.append(sublistdown)
                         sublistup   = []
                         sublistdown = []
                         up_txvalues_list.append(subtxlistup)
                         down_txvalues_list.append(subtxlistdown)
                         subtxlistup   = []
                         subtxlistdown = []
                         up_rxvalues_list.append(subrxlistup)
                         down_rxvalues_list.append(subrxlistdown)
                         subrxlistup   = []
                         subrxlistdown = []
                         cont = 1
                 list_uesup   = []
                 list_uesdown = []
                 for i in range(1,5):
                     if form_data['ues_up'+str(i)] == '':
                         list_uesup.append(0.0)
                     else:
                         list_uesup.append(float(form_data['ues_up'+str(i)]))
                     if form_data['ues_down'+str(i)] == '':
                         list_uesdown.append(0.0)
                     else:
                         list_uesdown.append(float(form_data['ues_down'+str(i)]))
                 onlyrx_list = form_data.getlist('onlyrx')
                 only_rx = {}
                 if '1' in onlyrx_list:
                     only_rx['up'] = True
                 else:
                     only_rx['up'] = False
                 if '2' in onlyrx_list:
                     only_rx['down'] = True
                 else:
                     only_rx['down'] = False
                 antenna = {'antenna_up': up_values_list, 'antenna_down': down_values_list}
                 tx      = {'up': up_txvalues_list, 'down': down_txvalues_list}
                 rx      = {'up': up_rxvalues_list, 'down': down_rxvalues_list}
                 ues     = {'up': list_uesup, 'down': list_uesdown}
                 name    = str(form_data['beam_name'])
                 beam_data = {'name': name, 'antenna': antenna, 'tx': tx, 'rx': rx, 'ues': ues, 'only_rx': only_rx}
                 return beam_data
             def abs_conf(request, id_conf):
                 conf     = get_object_or_404(ABSConfiguration, pk=id_conf)
+                beams = ABSBeam.objects.filter(abs_conf=conf)
+                #beams_dict = ast.literal_eval(conf.beams)
+                #beams = []
+                #for beam_id in range(1,len(beams_dict)+1):
+                #    beam = ABSBeam.objects.get(pk=beams_dict['beam'+str(beam_id)])
+                #    beams.append(beam)
-                beams_dict = ast.literal_eval(conf.beams)
+                #beams_id    = ast.literal_eval(conf.beams)
-                beams = []
-                for beam_id in range(1,len(beams_dict)+1):
-                    beam = ABSBeam.objects.get(pk=beams_dict['beam'+str(beam_id)])
-                    beams.append(beam)
-                beams_id    = ast.literal_eval(conf.beams)
                 ip=conf.device.ip_address
                 port=conf.device.port_address
                 kwargs = {}
                 kwargs['status'] = conf.device.get_status_display()
                 kwargs['dev_conf'] = conf
                 kwargs['dev_conf_keys'] = ['name',]
                 kwargs['title'] = 'ABS Configuration'
                 kwargs['suptitle'] = 'Details'
                 kwargs['no_play'] = True
                 kwargs['button'] = 'Edit Configuration'
                 #kwargs['no_play'] = True
-                kwargs['beams_id'] = beams_id
+                #kwargs['beams_id'] = beams_id
                 kwargs['beams']    = beams
                 kwargs['beam_selector'] = 0
                 #kwargs['my_data'] =  simplejson.dumps(beams)
                 kwargs['only_stop'] = True
                 ###### SIDEBAR ######
                 kwargs.update(sidebar(conf=conf))
                 return render(request, 'abs_conf.html', kwargs)
             def abs_conf_edit(request, id_conf):
                 conf     = get_object_or_404(ABSConfiguration, pk=id_conf)
-                beams_list = ast.literal_eval(conf.beams)
+                #beams_list = ast.literal_eval(conf.beams)
-                i = 1
+                #i = 1
-                beams = []
+                #beams = []
-                for b in beams_list:
+                #for b in beams_list:
-                    beam = ABSBeam.objects.get(pk=beams_list['beam'+str(i)])
+                #    beam = ABSBeam.objects.get(pk=beams_list['beam'+str(i)])
-                    beams.append(beam)
+                #    beams.append(beam)
-                    i=i+1
+                #    i=i+1
+                beams = ABSBeam.objects.filter(abs_conf=conf)
+                print beams
                 if request.method=='GET':
                     form = ABSConfigurationForm(instance=conf)
                 if request.method=='POST':
                     form = ABSConfigurationForm(request.POST, instance=conf)
                     if form.is_valid():
                         conf = form.save(commit=False)
                         conf.save()
                         return redirect('url_abs_conf', id_conf=conf.id)
                 ###### SIDEBAR ######
                 kwargs = {}
                 kwargs['dev_conf'] = conf
                 #kwargs['id_dev'] = conf.id
                 kwargs['id_conf'] = conf.id
                 kwargs['form'] = form
                 kwargs['abs_beams'] = beams
                 kwargs['title'] = 'Device Configuration'
                 kwargs['suptitle'] = 'Edit'
                 kwargs['button'] = 'Save'
                 kwargs['edit'] = True
                 return render(request, 'abs_conf_edit.html', kwargs)
             def add_beam(request, id_conf):
                 conf     = get_object_or_404(ABSConfiguration, pk=id_conf)
                 confs    = Configuration.objects.all()
                 if request.method=='GET':
                     #form = ABSBeamEditForm()
                     form = ABSBeamAddForm()
                 if request.method=='POST':
                     form = ABSBeamAddForm(request.POST)
                     beam_data = get_values_from_form(request.POST)
                     new_beam = ABSBeam(
                                name    =beam_data['name'],
                                antenna =json.dumps(beam_data['antenna']),
                                abs_conf=conf,
                                tx      =json.dumps(beam_data['tx']),
                                rx      =json.dumps(beam_data['rx']),
                                ues     =json.dumps(beam_data['ues']),
                                only_rx =json.dumps(beam_data['only_rx'])
                                )
                     new_beam.save()
                     #---Update 6bits configuration and add beam to abs configuration beams list.
                     new_beam.modules_6bits()
                     new_beam.add_beam2list()
                     messages.success(request, 'Beam: "%s" has been added.'  % new_beam.name)
                     return redirect('url_edit_abs_conf', conf.id)
                 ###### SIDEBAR ######
                 kwargs = {}
                 #kwargs['dev_conf'] = conf.device
                 #kwargs['id_dev'] = conf.device
                 kwargs['id_conf'] = conf.id
                 kwargs['form'] = form
                 kwargs['title'] = 'ABS Beams'
                 kwargs['suptitle'] = 'Add Beam'
                 kwargs['button'] = 'Add'
                 kwargs['no_sidebar'] = True
                 #kwargs['previous'] = conf.get_absolute_url_edit()
                 kwargs['edit'] = True
                 return render(request, 'abs_add_beam.html', kwargs)
             def edit_beam(request, id_conf, id_beam):
                 conf = get_object_or_404(ABSConfiguration, pk=id_conf)
                 beam = get_object_or_404(ABSBeam, pk=id_beam)
                 if request.method=='GET':
                     form = ABSBeamEditForm(initial={'beam': beam})
                 if request.method=='POST':
                     form = ABSBeamEditForm(request.POST)
                     beam_data = get_values_from_form(request.POST)
                     beam.dict_to_parms(beam_data)
                     beam.save()
                     messages.success(request, 'Beam: "%s" has been updated.'  % beam.name)
                     return redirect('url_edit_abs_conf', conf.id)
                 ###### SIDEBAR ######
                 kwargs = {}
                 kwargs['id_conf'] = conf.id
                 kwargs['form'] = form
                 kwargs['title'] = 'ABS Beams'
                 kwargs['suptitle'] = 'Edit Beam'
                 kwargs['button'] = 'Save'
                 kwargs['no_sidebar'] = True
                 #kwargs['previous'] = conf.get_absolute_url_edit()
                 kwargs['edit'] = True
                 return render(request, 'abs_edit_beam.html', kwargs)
             def remove_beam(request, id_conf, id_beam):
                 conf     = get_object_or_404(ABSConfiguration, pk=id_conf)
                 beam     = get_object_or_404(ABSBeam, pk=id_beam)
                 if request.method=='POST':
                     if beam:
                         try:
                             beam.remove_beamfromlist()
                             beam.delete()
                             messages.success(request, 'Beam: "%s" has been deleted.'  % beam)
                         except:
                             messages.error(request, 'Unable to delete beam: "%s".' % beam)
                     return redirect('url_edit_abs_conf', conf.id)
                 ###### SIDEBAR ######
                 kwargs = {}
                 kwargs['object'] = beam
                 kwargs['delete'] = True
                 kwargs['title'] = 'Delete'
                 kwargs['suptitle'] = 'Beam'
                 kwargs['previous'] = conf.get_absolute_url_edit()
                 return render(request, 'confirm.html', kwargs)
             def plot_patterns(request, id_conf, id_beam=None):
                 kwargs = {}
                 conf = get_object_or_404(ABSConfiguration, pk=id_conf)
                 beams = ABSBeam.objects.filter(abs_conf=conf)
                 if id_beam:
                     beam  = get_object_or_404(ABSBeam, pk=id_beam)
                     kwargs['beam']       = beam
                 ###### SIDEBAR ######
                 kwargs['dev_conf']   = conf.device
                 kwargs['id_dev']     = conf.device
                 kwargs['id_conf']    = conf.id
                 kwargs['abs_beams']  = beams
                 kwargs['title']      = 'ABS Patterns'
                 kwargs['suptitle']   = conf.name
                 kwargs['no_sidebar'] = True
                 return render(request, 'abs_patterns.html', kwargs)
             def plot_pattern(request, id_conf, id_beam, antenna):
                 if antenna=='down':
                     sleep(3)
                 conf = get_object_or_404(ABSConfiguration, pk=id_conf)
                 beam = get_object_or_404(ABSBeam, pk=id_beam)
                 name = conf.experiment.name
                 just_rx = 1 if json.loads(beam.only_rx)[antenna] else 0
                 phases = json.loads(beam.antenna)['antenna_{}'.format(antenna)]
                 gain_tx = json.loads(beam.tx)[antenna]
                 gain_rx = json.loads(beam.rx)[antenna]
                 ues = json.loads(beam.ues)[antenna]
                 newOverJro = overJroShow(name)
                 fig = newOverJro.plotPattern2(datetime.today(), phases, gain_tx, gain_rx, ues, just_rx)
                 response=HttpResponse(content_type='image/png')
                 fig.canvas.print_png(response)
                 return response

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