views.py
574 lines
| 17.2 KiB
| text/x-python
|
PythonLexer
Renato-TUF
|
r355 | from django.shortcuts import render | ||
Fiorella Quino
|
r166 | from django.template import RequestContext | ||
| from django.shortcuts import redirect, render, get_object_or_404 | ||||
| from django.contrib import messages | ||||
|
Fiorella Quino
|
r177 | from django.conf import settings | ||
| from django.http import HttpResponse | ||||
| r338 | from django.urls import reverse | |||
| r313 | from django.views.decorators.csrf import csrf_exempt | |||
Juan C. Espinoza
|
r326 | from django.utils.safestring import mark_safe | ||
|
Fiorella Quino
|
r177 | |||
| from datetime import datetime | ||||
| from time import sleep | ||||
| import os | ||||
|
Juan C. Espinoza
|
r309 | import io | ||
|
Juan C. Espinoza
|
r0 | |||
|
Fiorella Quino
|
r205 | from apps.main.models import Device, Configuration, Experiment | ||
|
Fiorella Quino
|
r166 | from apps.main.views import sidebar | ||
| from .models import ABSConfiguration, ABSBeam | ||||
|
Fiorella Quino
|
r190 | from .forms import ABSConfigurationForm, ABSBeamEditForm, ABSBeamAddForm, ABSImportForm | ||
|
Fiorella Quino
|
r177 | |||
| from .utils.overJroShow import overJroShow | ||||
| r338 | #from .utils.OverJRO import OverJRO | |||
gonzalesluisfrancisco
|
r345 | #Create your views here. | ||
|
Fiorella Quino
|
r166 | import json, ast | ||
|
Renato Huallpa
|
r383 | from .mqtt import client as mqtt_client | ||
| from radarsys.socketconfig import sio as sio | ||||
|
Fiorella Quino
|
r166 | |||
| 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 | ||||
Juan C. Espinoza
|
r307 | def abs_conf(request, id_conf): | ||
|
Fiorella Quino
|
r166 | |||
|
Juan C. Espinoza
|
r307 | conf = get_object_or_404(ABSConfiguration, pk=id_conf) | ||
| beams = ABSBeam.objects.filter(abs_conf=conf) | ||||
|
Fiorella Quino
|
r182 | #------------Colors for Active Beam:------------- | ||
|
Juan C. Espinoza
|
r307 | all_status = {} | ||
|
Fiorella Quino
|
r203 | module_messages = json.loads(conf.module_messages) | ||
|
Fiorella Quino
|
r182 | |||
| color_status = {} | ||||
|
Juan C. Espinoza
|
r307 | for i, status in enumerate(conf.module_status): | ||
| if status == '3': #Running background-color: #00cc00; | ||||
| all_status['{}'.format(i+1)] = 2 | ||||
| color_status['{}'.format(i+1)] = 'class=text-success'#'bgcolor=#00cc00' | ||||
|
Juan C. Espinoza
|
r326 | elif status == '2': | ||
| all_status['{}'.format(i+1)] = 1 | ||||
| color_status['{}'.format(i+1)] = 'class=text-info' | ||||
|
Juan C. Espinoza
|
r307 | elif status == '1': #Connected background-color: #ee902c; | ||
| all_status['{}'.format(i+1)] = 1 | ||||
| color_status['{}'.format(i+1)] = 'class=text-warning'#'bgcolor=#ee902c' | ||||
| else: #Disconnected background-color: #ff0000; | ||||
| all_status['{}'.format(i+1)] = 0 | ||||
| color_status['{}'.format(i+1)] = 'class=text-danger'#'bgcolor=#FF0000' | ||||
|
Fiorella Quino
|
r182 | #------------------------------------------------ | ||
|
Fiorella Quino
|
r166 | |||
| kwargs = {} | ||||
|
Fiorella Quino
|
r199 | kwargs['connected_modules'] = str(conf.connected_modules())+'/64' | ||
|
Fiorella Quino
|
r166 | kwargs['dev_conf'] = conf | ||
|
Juan C. Espinoza
|
r307 | |||
|
Fiorella Quino
|
r206 | if conf.operation_mode == 0: | ||
|
Juan C. Espinoza
|
r316 | kwargs['dev_conf_keys'] = ['label', 'operation_mode'] | ||
|
Fiorella Quino
|
r206 | else: | ||
|
Juan C. Espinoza
|
r316 | kwargs['dev_conf_keys'] = ['label', 'operation_mode', 'operation_value'] | ||
|
Fiorella Quino
|
r166 | |||
| kwargs['title'] = 'ABS Configuration' | ||||
| kwargs['suptitle'] = 'Details' | ||||
| kwargs['button'] = 'Edit Configuration' | ||||
|
Juan C. Espinoza
|
r307 | |||
| if conf.active_beam != 0: | ||||
| kwargs['active_beam'] = int(conf.active_beam) | ||||
| kwargs['beams'] = beams | ||||
| kwargs['modules_status'] = all_status | ||||
|
Fiorella Quino
|
r182 | kwargs['color_status'] = color_status | ||
|
Fiorella Quino
|
r203 | kwargs['module_messages'] = module_messages | ||
|
Fiorella Quino
|
r166 | ###### SIDEBAR ###### | ||
| kwargs.update(sidebar(conf=conf)) | ||||
| return render(request, 'abs_conf.html', kwargs) | ||||
|
Renato Huallpa
|
r394 | def abs_conf_mqtt(request, id_conf): | ||
| print("Estoy en abs_conf_mqtt",flush=True) | ||||
| conf = get_object_or_404(ABSConfiguration, pk=id_conf) | ||||
| beams = ABSBeam.objects.filter(abs_conf=conf) | ||||
| #------------Colors for Active Beam:------------- | ||||
| all_status = {} | ||||
| module_messages = json.loads(conf.module_messages) | ||||
| kwargs = {} | ||||
| kwargs['connected_modules'] = str(conf.connected_modules())+'/64' | ||||
| kwargs['dev_conf'] = conf | ||||
| if conf.operation_mode == 0: | ||||
| kwargs['dev_conf_keys'] = ['label', 'operation_mode'] | ||||
| else: | ||||
| kwargs['dev_conf_keys'] = ['label', 'operation_mode', 'operation_value'] | ||||
| kwargs['title'] = 'ABS Configuration' | ||||
| kwargs['suptitle'] = 'Details' | ||||
| kwargs['button'] = 'Edit Configuration' | ||||
| if conf.active_beam != 0: | ||||
| kwargs['active_beam'] = int(conf.active_beam) | ||||
|
Fiorella Quino
|
r258 | |||
|
Renato Huallpa
|
r394 | kwargs['mqtt']=True | ||
| kwargs['beams'] = beams | ||||
| kwargs['modules_status'] = all_status | ||||
| kwargs['module_messages'] = module_messages | ||||
| ###### SIDEBAR ###### | ||||
| kwargs.update(sidebar(conf=conf)) | ||||
| print("conf.active_beam: {}",format(conf.active_beam)) | ||||
| # print(conf.beam.pk) | ||||
| return render(request, 'abs_conf_mqtt.html', kwargs) | ||||
| # // console.log(beam.pk); | ||||
| # // console.log(active_beam); | ||||
|
Renato Huallpa
|
r385 | # def abs_conf_mqtt(request, id_conf): | ||
| # # socket.on('beams_ack',function(data){ | ||||
| # ack=data; | ||||
| # console.log("ack") | ||||
| # console.log(ack) | ||||
| # }) | ||||
|
Fiorella Quino
|
r166 | def abs_conf_edit(request, id_conf): | ||
| conf = get_object_or_404(ABSConfiguration, pk=id_conf) | ||||
|
Fiorella Quino
|
r190 | |||
|
Fiorella Quino
|
r181 | beams = ABSBeam.objects.filter(abs_conf=conf) | ||
|
Fiorella Quino
|
r166 | |||
| 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() | ||||
|
Renato Huallpa
|
r394 | return redirect('url_abs_conf_mqtt', id_conf=conf.id) | ||
|
Fiorella Quino
|
r166 | |||
| ###### 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' | ||||
|
Renato Huallpa
|
r394 | kwargs['mqtt']=True | ||
|
Fiorella Quino
|
r166 | |||
| kwargs['edit'] = True | ||||
| return render(request, 'abs_conf_edit.html', kwargs) | ||||
| r313 | @csrf_exempt | |||
| def abs_conf_alert(request): | ||||
| if request.method == 'POST': | ||||
| r338 | print (request.POST) | |||
| r313 | return HttpResponse(json.dumps({'result':1}), content_type='application/json') | |||
| else: | ||||
| return redirect('index') | ||||
|
Fiorella Quino
|
r166 | |||
|
Fiorella Quino
|
r190 | def import_file(request, id_conf): | ||
| conf = get_object_or_404(ABSConfiguration, pk=id_conf) | ||||
| if request.method=='POST': | ||||
| form = ABSImportForm(request.POST, request.FILES) | ||||
| if form.is_valid(): | ||||
| try: | ||||
| parms = conf.import_from_file(request.FILES['file_name']) | ||||
| if parms: | ||||
| conf.update_from_file(parms) | ||||
| messages.success(request, 'Configuration "%s" loaded succesfully' % request.FILES['file_name']) | ||||
| return redirect(conf.get_absolute_url_edit()) | ||||
| except Exception as e: | ||||
| messages.error(request, 'Error parsing file: "%s" - %s' % (request.FILES['file_name'], e)) | ||||
| else: | ||||
| messages.warning(request, 'Your current configuration will be replaced') | ||||
| form = ABSImportForm() | ||||
| kwargs = {} | ||||
| kwargs['form'] = form | ||||
| kwargs['title'] = 'ABS Configuration' | ||||
| kwargs['suptitle'] = 'Import file' | ||||
| kwargs['button'] = 'Upload' | ||||
| kwargs['previous'] = conf.get_absolute_url() | ||||
| return render(request, 'abs_import.html', kwargs) | ||||
|
Fiorella Quino
|
r183 | def send_beam(request, id_conf, id_beam): | ||
| conf = get_object_or_404(ABSConfiguration, pk=id_conf) | ||||
|
Juan C. Espinoza
|
r326 | |||
|
Juan C. Espinoza
|
r329 | abs = Configuration.objects.filter(pk=conf.device.conf_active).first() | ||
| r338 | if abs!=conf: | |||
|
Juan C. Espinoza
|
r326 | url = '#' if abs is None else abs.get_absolute_url() | ||
| label = 'None' if abs is None else abs.label | ||||
| messages.warning( | ||||
| request, | ||||
| mark_safe('The current configuration has not been written in the modules, the active configuration is <a href="{}">{}</a>'.format( | ||||
| url, | ||||
| label | ||||
| )) | ||||
| ) | ||||
| return redirect(conf.get_absolute_url()) | ||||
|
Fiorella Quino
|
r183 | beam = get_object_or_404(ABSBeam, pk=id_beam) | ||
|
Juan C. Espinoza
|
r307 | |||
|
Juan C. Espinoza
|
r333 | if request.method == 'POST': | ||
| beams_list = ABSBeam.objects.filter(abs_conf=conf) | ||||
| conf.active_beam = id_beam | ||||
| i = 0 | ||||
| for b in beams_list: | ||||
| if b.id == int(id_beam): | ||||
| break | ||||
| else: | ||||
| i += 1 | ||||
| beam_pos = i + 1 #Estandarizar | ||||
|
Renato Huallpa
|
r393 | print('{} Position {}'.format(beam.name,str(beam_pos))) | ||
|
Juan C. Espinoza
|
r333 | conf.send_beam(beam_pos) | ||
| return redirect('url_abs_conf', conf.id) | ||||
| kwargs = { | ||||
| 'title': 'ABS', | ||||
| 'suptitle': conf.label, | ||||
|
Renato Huallpa
|
r394 | 'message': 'Are you sure you want to change ABS Beam through SEND BEAM to: {}?'.format(beam.name), | ||
|
Juan C. Espinoza
|
r333 | 'delete': False | ||
| } | ||||
| kwargs['menu_configurations'] = 'active' | ||||
| return render(request, 'confirm.html', kwargs) | ||||
|
Fiorella Quino
|
r166 | |||
|
Renato Huallpa
|
r393 | def change_beam_mqtt(request, id_conf, id_beam): | ||
| conf = get_object_or_404(ABSConfiguration, pk=id_conf) | ||||
|
Renato Huallpa
|
r394 | print("conf: {}".format(conf),flush=True) | ||
|
Renato Huallpa
|
r393 | |||
| abs = Configuration.objects.filter(pk=conf.device.conf_active).first() | ||||
|
Renato Huallpa
|
r394 | print("abs: {}".format(abs),flush=True) | ||
|
Renato Huallpa
|
r393 | if abs!=conf: | ||
| url = '#' if abs is None else abs.get_absolute_url() | ||||
| label = 'None' if abs is None else abs.label | ||||
| messages.warning( | ||||
| request, | ||||
| mark_safe('The current configuration has not been written in the modules, the active configuration is <a href="{}">{}</a>'.format( | ||||
| url, | ||||
| label | ||||
| )) | ||||
| ) | ||||
|
Renato Huallpa
|
r394 | return redirect(conf.get_absolute_mqtt_url()) | ||
|
Renato Huallpa
|
r393 | |||
| beams = ABSBeam.objects.filter(abs_conf=conf) | ||||
| beam = get_object_or_404(ABSBeam, pk=id_beam) | ||||
| if request.method == 'POST': | ||||
| beams_list = ABSBeam.objects.filter(abs_conf=conf) | ||||
| conf.active_beam = id_beam | ||||
|
Renato Huallpa
|
r394 | |||
|
Renato Huallpa
|
r393 | i = 0 | ||
| for b in beams_list: | ||||
| if b.id == int(id_beam): | ||||
| break | ||||
| else: | ||||
| i += 1 | ||||
| beam_pos = i + 1 #Estandarizar | ||||
|
Renato Huallpa
|
r394 | print('{} Position {}'.format(beam.name,str(beam_pos)),flush=True) | ||
|
Renato Huallpa
|
r393 | conf.change_beam_mqtt(beam_pos) | ||
| # return redirect('url_abs_conf', conf.id) | ||||
|
Renato Huallpa
|
r394 | return redirect('url_abs_conf_mqtt', conf.id) | ||
| # return render(request, 'abs_conf_mqtt.html',kwargs) | ||||
|
Renato Huallpa
|
r393 | |||
| kwargs = { | ||||
| 'title': 'ABS', | ||||
|
Renato Huallpa
|
r394 | 'mqtt':True, | ||
|
Renato Huallpa
|
r393 | 'suptitle': conf.label, | ||
| 'message': 'Are you sure you want to change ABS Beam through MQTT to: {}?'.format(beam.name), | ||||
| 'delete': False | ||||
| } | ||||
| kwargs['menu_configurations'] = 'active' | ||||
| return render(request, 'confirm.html', kwargs) | ||||
|
Fiorella Quino
|
r166 | |||
| def add_beam(request, id_conf): | ||||
| conf = get_object_or_404(ABSConfiguration, pk=id_conf) | ||||
| confs = Configuration.objects.all() | ||||
| if request.method=='GET': | ||||
| form = ABSBeamAddForm() | ||||
| if request.method=='POST': | ||||
| form = ABSBeamAddForm(request.POST) | ||||
| beam_data = get_values_from_form(request.POST) | ||||
| new_beam = ABSBeam( | ||||
|
gonzalesluisfrancisco
|
r345 | name = beam_data['name'], | ||
| antenna = json.dumps(beam_data['antenna']), | ||||
|
Juan C. Espinoza
|
r307 | abs_conf = conf, | ||
|
gonzalesluisfrancisco
|
r345 | 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']) | ||||
|
Fiorella Quino
|
r166 | ) | ||
| new_beam.save() | ||||
| messages.success(request, 'Beam: "%s" has been added.' % new_beam.name) | ||||
| return redirect('url_edit_abs_conf', conf.id) | ||||
| ###### SIDEBAR ###### | ||||
| kwargs = {} | ||||
|
gonzalesluisfrancisco
|
r345 | #kwargs['dev_conf'] = conf.device | ||
| #kwargs['id_dev'] = conf.device | ||||
| #kwargs['previous'] = conf.get_absolute_url_edit() | ||||
| kwargs['id_conf'] = conf.id | ||||
| kwargs['form'] = form | ||||
| kwargs['title'] = 'ABS Beams' | ||||
| kwargs['suptitle'] = 'Add Beam' | ||||
| kwargs['button'] = 'Add' | ||||
|
Fiorella Quino
|
r166 | kwargs['no_sidebar'] = True | ||
|
gonzalesluisfrancisco
|
r345 | kwargs['edit'] = True | ||
|
Fiorella Quino
|
r166 | |||
| 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 | ||||
|
Fiorella Quino
|
r168 | return render(request, 'abs_edit_beam.html', kwargs) | ||
|
Fiorella Quino
|
r166 | |||
| 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.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) | ||||
|
Fiorella Quino
|
r177 | |||
|
Juan C. Espinoza
|
r180 | def plot_patterns(request, id_conf, id_beam=None): | ||
|
Fiorella Quino
|
r177 | |||
| kwargs = {} | ||||
|
Juan C. Espinoza
|
r180 | conf = get_object_or_404(ABSConfiguration, pk=id_conf) | ||
| beams = ABSBeam.objects.filter(abs_conf=conf) | ||||
|
Fiorella Quino
|
r190 | |||
|
Juan C. Espinoza
|
r180 | if id_beam: | ||
| beam = get_object_or_404(ABSBeam, pk=id_beam) | ||||
|
Juan C. Espinoza
|
r309 | kwargs['beam'] = beam | ||
|
Fiorella Quino
|
r190 | |||
| ###### SIDEBAR ###### | ||||
|
Fiorella Quino
|
r177 | |||
| 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) | ||||
|
Juan C. Espinoza
|
r180 | def plot_pattern(request, id_conf, id_beam, antenna): | ||
|
Fiorella Quino
|
r190 | |||
|
Juan C. Espinoza
|
r180 | if antenna=='down': | ||
| sleep(3) | ||||
|
Fiorella Quino
|
r190 | |||
|
Juan C. Espinoza
|
r180 | conf = get_object_or_404(ABSConfiguration, pk=id_conf) | ||
| beam = get_object_or_404(ABSBeam, pk=id_beam) | ||||
|
Fiorella Quino
|
r190 | just_rx = 1 if json.loads(beam.only_rx)[antenna] else 0 | ||
|
Juan C. Espinoza
|
r180 | 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] | ||||
|
Juan C. Espinoza
|
r309 | newOverJro = overJroShow(beam.name) | ||
|
Fiorella Quino
|
r190 | fig = newOverJro.plotPattern2(datetime.today(), phases, gain_tx, gain_rx, ues, just_rx) | ||
|
Juan C. Espinoza
|
r309 | buf = io.BytesIO() | ||
| fig.savefig(buf, format='png') | ||||
| response = HttpResponse(buf.getvalue(), content_type='image/png') | ||||
|
Fiorella Quino
|
r177 | return response | ||
| r313 | ||||
|
Renato Huallpa
|
r383 | import os | ||
| from django.http import HttpResponse | ||||
| @sio.on('connection-bind') | ||||
| def abs_connection_bind(sid, data): | ||||
| print("sid:",sid,"data",data) | ||||
| @sio.on('disconnect') | ||||
| def abs_test_disconnect(sid): | ||||
| print("Disconnected") | ||||
| @sio.event | ||||
| def abs_send_beam_up(sid, message): | ||||
| mqtt_client.publish('abs/beams_up', message['data']) | ||||
| @sio.event | ||||
| def abs_send_beam_down(sid, message): | ||||
| mqtt_client.publish('abs/beams_down', message['data']) | ||||
|
Renato Huallpa
|
r394 | # @sio.event | ||
| # def change_beam(sid,message): | ||||
| # data=str(message['data']) | ||||
| # data=data[16] | ||||
| # mqtt_client.publish('abs/change_beam',data) | ||||
|
Renato Huallpa
|
r383 | |||
