views.py
1864 lines
| 57.7 KiB
| text/x-python
|
PythonLexer
Juan C. Espinoza
|
r239 | import ast | |
| import json | |||
|
Juan C. Espinoza
|
r316 | import hashlib | |
Juan C. Espinoza
|
r306 | from datetime import datetime, timedelta | |
|
Juan C. Espinoza
|
r196 | ||
Miguel Urco
|
r20 | from django.shortcuts import render, redirect, get_object_or_404, HttpResponse | |
|
Juan C. Espinoza
|
r106 | from django.utils.safestring import mark_safe | |
Fiorella Quino
|
r84 | from django.http import HttpResponseRedirect | |
| from django.core.urlresolvers import reverse | |||
|
Juan C. Espinoza
|
r138 | from django.db.models import Q | |
| from django.core.paginator import Paginator, EmptyPage, PageNotAnInteger | |||
|
Miguel Urco
|
r30 | from django.contrib import messages | |
|
Juan C. Espinoza
|
r172 | from django.http.request import QueryDict | |
|
Juan C. Espinoza
|
r316 | from django.contrib.auth.decorators import login_required, user_passes_test | |
|
Juan C. Espinoza
|
r172 | ||
| try: | |||
| from urllib.parse import urlencode | |||
| except ImportError: | |||
| from urllib import urlencode | |||
|
Juan C. Espinoza
|
r6 | ||
|
Juan C. Espinoza
|
r85 | from .forms import CampaignForm, ExperimentForm, DeviceForm, ConfigurationForm, LocationForm, UploadFileForm, DownloadFileForm, OperationForm, NewForm | |
|
Juan C. Espinoza
|
r219 | from .forms import OperationSearchForm, FilterForm, ChangeIpForm | |
|
Juan C. Espinoza
|
r172 | ||
| r311 | from .tasks import task_start | ||
|
Juan C. Espinoza
|
r196 | ||
|
Juan C. Espinoza
|
r238 | from apps.rc.forms import RCConfigurationForm, RCLineCode, RCMixConfigurationForm | |
|
Juan C. Espinoza
|
r172 | from apps.dds.forms import DDSConfigurationForm | |
|
Miguel Urco
|
r13 | from apps.jars.forms import JARSConfigurationForm | |
|
Juan C. Espinoza
|
r172 | from apps.cgs.forms import CGSConfigurationForm | |
|
Miguel Urco
|
r13 | from apps.abs.forms import ABSConfigurationForm | |
|
Juan C. Espinoza
|
r172 | from apps.usrp.forms import USRPConfigurationForm | |
|
Fiorella Quino
|
r295 | from .utils import Params | |
|
Miguel Urco
|
r13 | ||
|
Fiorella Quino
|
r252 | from .models import Campaign, Experiment, Device, Configuration, Location, RunningExperiment, DEV_STATES | |
|
Juan C. Espinoza
|
r6 | from apps.cgs.models import CGSConfiguration | |
|
Fiorella Quino
|
r151 | from apps.jars.models import JARSConfiguration, EXPERIMENT_TYPE | |
|
Miguel Urco
|
r13 | from apps.usrp.models import USRPConfiguration | |
|
Juan C. Espinoza
|
r6 | from apps.abs.models import ABSConfiguration | |
|
Juan C. Espinoza
|
r106 | from apps.rc.models import RCConfiguration, RCLine, RCLineType | |
|
Juan C. Espinoza
|
r6 | from apps.dds.models import DDSConfiguration | |
|
Juan C. Espinoza
|
r0 | ||
| r311 | from radarsys.celery import app | ||
|
Fiorella Quino
|
r211 | ||
|
Miguel Urco
|
r13 | CONF_FORMS = { | |
| 'rc': RCConfigurationForm, | |||
| 'dds': DDSConfigurationForm, | |||
| 'jars': JARSConfigurationForm, | |||
| 'cgs': CGSConfigurationForm, | |||
| 'abs': ABSConfigurationForm, | |||
| 'usrp': USRPConfigurationForm, | |||
| } | |||
| CONF_MODELS = { | |||
|
Juan C. Espinoza
|
r6 | 'rc': RCConfiguration, | |
| 'dds': DDSConfiguration, | |||
| 'jars': JARSConfiguration, | |||
| 'cgs': CGSConfiguration, | |||
| 'abs': ABSConfiguration, | |||
|
Miguel Urco
|
r13 | 'usrp': USRPConfiguration, | |
|
Juan C. Espinoza
|
r6 | } | |
|
Juan C. Espinoza
|
r106 | MIX_MODES = { | |
|
Juan C. Espinoza
|
r112 | '0': 'P', | |
| '1': 'S', | |||
| } | |||
| MIX_OPERATIONS = { | |||
|
Juan C. Espinoza
|
r106 | '0': 'OR', | |
| '1': 'XOR', | |||
| '2': 'AND', | |||
|
Juan C. Espinoza
|
r112 | '3': 'NAND', | |
|
Juan C. Espinoza
|
r106 | } | |
|
Juan C. Espinoza
|
r316 | ||
| def is_developer(user): | |||
| groups = [str(g.name) for g in user.groups.all()] | |||
| return 'Developer' in groups or user.is_staff | |||
| def is_operator(user): | |||
| groups = [str(g.name) for g in user.groups.all()] | |||
| return 'Operator' in groups or user.is_staff | |||
| def has_been_modified(model): | |||
| prev_hash = model.hash | |||
| new_hash = hashlib.sha256(str(model.parms_to_dict)).hexdigest() | |||
| if prev_hash != new_hash: | |||
| model.hash = new_hash | |||
| model.save() | |||
| return True | |||
| return False | |||
|
Juan C. Espinoza
|
r6 | def index(request): | |
|
Juan C. Espinoza
|
r316 | kwargs = {'no_sidebar': True} | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | return render(request, 'index.html', kwargs) | |
|
Juan C. Espinoza
|
r89 | ||
|
Miguel Urco
|
r41 | def locations(request): | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | page = request.GET.get('page') | |
| order = ('name',) | |||
|
Juan C. Espinoza
|
r172 | ||
| kwargs = get_paginator(Location, page, order) | |||
|
Juan C. Espinoza
|
r138 | kwargs['keys'] = ['name', 'description'] | |
| kwargs['title'] = 'Radar System' | |||
|
Miguel Urco
|
r41 | kwargs['suptitle'] = 'List' | |
|
Juan C. Espinoza
|
r196 | kwargs['no_sidebar'] = True | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | return render(request, 'base_list.html', kwargs) | |
|
Miguel Urco
|
r41 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Miguel Urco
|
r41 | def location(request, id_loc): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r41 | location = get_object_or_404(Location, pk=id_loc) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r41 | kwargs = {} | |
| kwargs['location'] = location | |||
| kwargs['location_keys'] = ['name', 'description'] | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r41 | kwargs['title'] = 'Location' | |
| kwargs['suptitle'] = 'Details' | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r41 | return render(request, 'location.html', kwargs) | |
|
Fiorella Quino
|
r69 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r41 | def location_new(request): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r41 | if request.method == 'GET': | |
| form = LocationForm() | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r41 | if request.method == 'POST': | |
| form = LocationForm(request.POST) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r41 | if form.is_valid(): | |
| form.save() | |||
| return redirect('url_locations') | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r41 | kwargs = {} | |
| kwargs['form'] = form | |||
|
Juan C. Espinoza
|
r138 | kwargs['title'] = 'Radar System' | |
|
Miguel Urco
|
r41 | kwargs['suptitle'] = 'New' | |
| kwargs['button'] = 'Create' | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | return render(request, 'base_edit.html', kwargs) | |
|
Miguel Urco
|
r41 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r41 | def location_edit(request, id_loc): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r41 | location = get_object_or_404(Location, pk=id_loc) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'GET': | |
|
Miguel Urco
|
r41 | form = LocationForm(instance=location) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'POST': | |
|
Miguel Urco
|
r41 | form = LocationForm(request.POST, instance=location) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r41 | if form.is_valid(): | |
| form.save() | |||
| return redirect('url_locations') | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r41 | kwargs = {} | |
| kwargs['form'] = form | |||
| kwargs['title'] = 'Location' | |||
| kwargs['suptitle'] = 'Edit' | |||
| kwargs['button'] = 'Update' | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | return render(request, 'base_edit.html', kwargs) | |
|
Miguel Urco
|
r41 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r41 | def location_delete(request, id_loc): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r41 | location = get_object_or_404(Location, pk=id_loc) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'POST': | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r320 | if is_developer(request.user): | |
|
Miguel Urco
|
r41 | location.delete() | |
| return redirect('url_locations') | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r89 | messages.error(request, 'Not enough permission to delete this object') | |
| return redirect(location.get_absolute_url()) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r89 | kwargs = { | |
|
Juan C. Espinoza
|
r316 | 'title': 'Delete', | |
| 'suptitle': 'Location', | |||
| 'object': location, | |||
| 'delete': True | |||
| } | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r89 | return render(request, 'confirm.html', kwargs) | |
|
Miguel Urco
|
r41 | ||
|
Miguel Urco
|
r13 | def devices(request): | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | page = request.GET.get('page') | |
|
Juan C. Espinoza
|
r316 | order = ('location', 'device_type') | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | filters = request.GET.copy() | |
| kwargs = get_paginator(Device, page, order, filters) | |||
| form = FilterForm(initial=request.GET, extra_fields=['tags']) | |||
| kwargs['keys'] = ['device_type', 'location', | |||
| 'ip_address', 'port_address', 'actions'] | |||
|
Miguel Urco
|
r13 | kwargs['title'] = 'Device' | |
| kwargs['suptitle'] = 'List' | |||
|
Juan C. Espinoza
|
r196 | kwargs['no_sidebar'] = True | |
|
Juan C. Espinoza
|
r316 | kwargs['form'] = form | |
| kwargs['add_url'] = reverse('url_add_device') | |||
| filters.pop('page', None) | |||
| kwargs['q'] = urlencode(filters) | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_devices'] = 'active' | |
|
Juan C. Espinoza
|
r138 | return render(request, 'base_list.html', kwargs) | |
|
Juan C. Espinoza
|
r2 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Miguel Urco
|
r13 | def device(request, id_dev): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r20 | device = get_object_or_404(Device, pk=id_dev) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r2 | kwargs = {} | |
|
Miguel Urco
|
r13 | kwargs['device'] = device | |
|
Juan C. Espinoza
|
r316 | kwargs['device_keys'] = ['device_type', | |
| 'ip_address', 'port_address', 'description'] | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | kwargs['title'] = 'Device' | |
| kwargs['suptitle'] = 'Details' | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_devices'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | return render(request, 'device.html', kwargs) | |
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r19 | def device_new(request): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | if request.method == 'GET': | |
| form = DeviceForm() | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | if request.method == 'POST': | |
| form = DeviceForm(request.POST) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | if form.is_valid(): | |
| form.save() | |||
| return redirect('url_devices') | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | kwargs = {} | |
| kwargs['form'] = form | |||
| kwargs['title'] = 'Device' | |||
| kwargs['suptitle'] = 'New' | |||
| kwargs['button'] = 'Create' | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_devices'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | return render(request, 'base_edit.html', kwargs) | |
|
Juan C. Espinoza
|
r6 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r19 | def device_edit(request, id_dev): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r20 | device = get_object_or_404(Device, pk=id_dev) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'GET': | |
|
Miguel Urco
|
r13 | form = DeviceForm(instance=device) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'POST': | |
|
Miguel Urco
|
r13 | form = DeviceForm(request.POST, instance=device) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r2 | if form.is_valid(): | |
| form.save() | |||
|
Juan C. Espinoza
|
r89 | return redirect(device.get_absolute_url()) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | kwargs = {} | |
| kwargs['form'] = form | |||
| kwargs['title'] = 'Device' | |||
| kwargs['suptitle'] = 'Edit' | |||
| kwargs['button'] = 'Update' | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_devices'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | return render(request, 'base_edit.html', kwargs) | |
|
Juan C. Espinoza
|
r6 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r19 | def device_delete(request, id_dev): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r20 | device = get_object_or_404(Device, pk=id_dev) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'POST': | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r320 | if is_developer(request.user): | |
|
Miguel Urco
|
r18 | device.delete() | |
| return redirect('url_devices') | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r89 | messages.error(request, 'Not enough permission to delete this object') | |
| return redirect(device.get_absolute_url()) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r89 | kwargs = { | |
|
Juan C. Espinoza
|
r316 | 'title': 'Delete', | |
| 'suptitle': 'Device', | |||
| 'object': device, | |||
| 'delete': True | |||
| } | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_devices'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r89 | return render(request, 'confirm.html', kwargs) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Juan C. Espinoza
|
r219 | def device_change_ip(request, id_dev): | |
| device = get_object_or_404(Device, pk=id_dev) | |||
|
Juan C. Espinoza
|
r316 | if request.method == 'POST': | |
|
Juan C. Espinoza
|
r219 | ||
|
Juan C. Espinoza
|
r320 | if is_developer(request.user): | |
|
Juan C. Espinoza
|
r219 | device.change_ip(**request.POST.dict()) | |
|
Juan C. Espinoza
|
r236 | level, message = device.message.split('|') | |
| messages.add_message(request, level, message) | |||
|
Juan C. Espinoza
|
r219 | else: | |
|
Juan C. Espinoza
|
r316 | messages.error( | |
| request, 'Not enough permission to delete this object') | |||
|
Juan C. Espinoza
|
r219 | return redirect(device.get_absolute_url()) | |
| kwargs = { | |||
|
Juan C. Espinoza
|
r316 | 'title': 'Device', | |
| 'suptitle': 'Change IP', | |||
| 'object': device, | |||
| 'previous': device.get_absolute_url(), | |||
| 'form': ChangeIpForm(initial={'ip_address': device.ip_address}), | |||
| 'message': ' ', | |||
| } | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_devices'] = 'active' | |
|
Juan C. Espinoza
|
r219 | ||
| return render(request, 'confirm.html', kwargs) | |||
|
Miguel Urco
|
r13 | def campaigns(request): | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | page = request.GET.get('page') | |
|
Juan C. Espinoza
|
r320 | order = ('-start_date',) | |
|
Juan C. Espinoza
|
r138 | filters = request.GET.copy() | |
| kwargs = get_paginator(Campaign, page, order, filters) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | form = FilterForm(initial=request.GET, extra_fields=[ | |
| 'range_date', 'tags', 'template']) | |||
| kwargs['keys'] = ['name', 'start_date', 'end_date', 'actions'] | |||
|
Miguel Urco
|
r13 | kwargs['title'] = 'Campaign' | |
| kwargs['suptitle'] = 'List' | |||
|
Juan C. Espinoza
|
r196 | kwargs['no_sidebar'] = True | |
|
Juan C. Espinoza
|
r172 | kwargs['form'] = form | |
|
Juan C. Espinoza
|
r316 | kwargs['add_url'] = reverse('url_add_campaign') | |
|
Juan C. Espinoza
|
r138 | filters.pop('page', None) | |
|
Juan C. Espinoza
|
r172 | kwargs['q'] = urlencode(filters) | |
|
Juan C. Espinoza
|
r320 | kwargs['menu_campaigns'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | return render(request, 'base_list.html', kwargs) | |
|
Miguel Urco
|
r13 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Miguel Urco
|
r13 | def campaign(request, id_camp): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r20 | campaign = get_object_or_404(Campaign, pk=id_camp) | |
|
Miguel Urco
|
r53 | experiments = Experiment.objects.filter(campaign=campaign) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | form = CampaignForm(instance=campaign) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | kwargs = {} | |
| kwargs['campaign'] = campaign | |||
|
Juan C. Espinoza
|
r316 | kwargs['campaign_keys'] = ['template', 'name', | |
| 'start_date', 'end_date', 'tags', 'description'] | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r89 | kwargs['experiments'] = experiments | |
|
Juan C. Espinoza
|
r316 | kwargs['experiment_keys'] = [ | |
| 'name', 'radar_system', 'start_time', 'end_time'] | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | kwargs['title'] = 'Campaign' | |
| kwargs['suptitle'] = 'Details' | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | kwargs['form'] = form | |
| kwargs['button'] = 'Add Experiment' | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_campaigns'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | return render(request, 'campaign.html', kwargs) | |
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r19 | def campaign_new(request): | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r85 | kwargs = {} | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | if request.method == 'GET': | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r85 | if 'template' in request.GET: | |
|
Juan C. Espinoza
|
r316 | if request.GET['template'] == '0': | |
| form = NewForm(initial={'create_from': 2}, | |||
|
Juan C. Espinoza
|
r85 | template_choices=Campaign.objects.filter(template=True).values_list('id', 'name')) | |
| else: | |||
| kwargs['button'] = 'Create' | |||
|
Juan C. Espinoza
|
r316 | kwargs['experiments'] = Configuration.objects.filter( | |
| experiment=request.GET['template']) | |||
|
Juan C. Espinoza
|
r85 | kwargs['experiment_keys'] = ['name', 'start_time', 'end_time'] | |
|
Juan C. Espinoza
|
r91 | camp = Campaign.objects.get(pk=request.GET['template']) | |
| form = CampaignForm(instance=camp, | |||
|
Juan C. Espinoza
|
r316 | initial={'name': '{}_{:%Y%m%d}'.format(camp.name, datetime.now()), | |
| 'template': False}) | |||
|
Juan C. Espinoza
|
r85 | elif 'blank' in request.GET: | |
| kwargs['button'] = 'Create' | |||
| form = CampaignForm() | |||
| else: | |||
| form = NewForm() | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | if request.method == 'POST': | |
|
Juan C. Espinoza
|
r85 | kwargs['button'] = 'Create' | |
| post = request.POST.copy() | |||
| experiments = [] | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r85 | for id_exp in post.getlist('experiments'): | |
| exp = Experiment.objects.get(pk=id_exp) | |||
| new_exp = exp.clone(template=False) | |||
| experiments.append(new_exp) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r85 | post.setlist('experiments', []) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r85 | form = CampaignForm(post) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | if form.is_valid(): | |
|
Juan C. Espinoza
|
r316 | campaign = form.save(commit=False) | |
| campaign.author = request.user | |||
|
Juan C. Espinoza
|
r85 | for exp in experiments: | |
| campaign.experiments.add(exp) | |||
| campaign.save() | |||
|
Miguel Urco
|
r13 | return redirect('url_campaign', id_camp=campaign.id) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | kwargs['form'] = form | |
| kwargs['title'] = 'Campaign' | |||
| kwargs['suptitle'] = 'New' | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_campaigns'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | return render(request, 'campaign_edit.html', kwargs) | |
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r19 | def campaign_edit(request, id_camp): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r20 | campaign = get_object_or_404(Campaign, pk=id_camp) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'GET': | |
|
Miguel Urco
|
r13 | form = CampaignForm(instance=campaign) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'POST': | |
|
Juan C. Espinoza
|
r91 | exps = campaign.experiments.all().values_list('pk', flat=True) | |
| post = request.POST.copy() | |||
| new_exps = post.getlist('experiments') | |||
| post.setlist('experiments', []) | |||
| form = CampaignForm(post, instance=campaign) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | if form.is_valid(): | |
|
Juan C. Espinoza
|
r91 | camp = form.save() | |
| for id_exp in new_exps: | |||
| if int(id_exp) in exps: | |||
| exps.pop(id_exp) | |||
| else: | |||
| exp = Experiment.objects.get(pk=id_exp) | |||
| if exp.template: | |||
| camp.experiments.add(exp.clone(template=False)) | |||
| else: | |||
| camp.experiments.add(exp) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r91 | for id_exp in exps: | |
| camp.experiments.remove(Experiment.objects.get(pk=id_exp)) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | return redirect('url_campaign', id_camp=id_camp) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | kwargs = {} | |
| kwargs['form'] = form | |||
| kwargs['title'] = 'Campaign' | |||
| kwargs['suptitle'] = 'Edit' | |||
| kwargs['button'] = 'Update' | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_campaigns'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | return render(request, 'campaign_edit.html', kwargs) | |
|
Juan C. Espinoza
|
r6 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r19 | def campaign_delete(request, id_camp): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r20 | campaign = get_object_or_404(Campaign, pk=id_camp) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'POST': | |
|
Juan C. Espinoza
|
r320 | if is_developer(request.user): | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r85 | for exp in campaign.experiments.all(): | |
| for conf in Configuration.objects.filter(experiment=exp): | |||
| conf.delete() | |||
| exp.delete() | |||
|
Miguel Urco
|
r18 | campaign.delete() | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r18 | return redirect('url_campaigns') | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r89 | messages.error(request, 'Not enough permission to delete this object') | |
| return redirect(campaign.get_absolute_url()) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r89 | kwargs = { | |
|
Juan C. Espinoza
|
r316 | 'title': 'Delete', | |
| 'suptitle': 'Campaign', | |||
| 'object': campaign, | |||
| 'delete': True | |||
| } | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_campaigns'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r89 | return render(request, 'confirm.html', kwargs) | |
|
Fiorella Quino
|
r211 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Fiorella Quino
|
r100 | def campaign_export(request, id_camp): | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r100 | campaign = get_object_or_404(Campaign, pk=id_camp) | |
|
Juan C. Espinoza
|
r172 | content = campaign.parms_to_dict() | |
|
Fiorella Quino
|
r100 | content_type = 'application/json' | |
|
Juan C. Espinoza
|
r316 | filename = '%s_%s.json' % (campaign.name, campaign.id) | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r100 | response = HttpResponse(content_type=content_type) | |
|
Juan C. Espinoza
|
r316 | response['Content-Disposition'] = 'attachment; filename="%s"' % filename | |
|
Fiorella Quino
|
r266 | response.write(json.dumps(content, indent=2)) | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r100 | return response | |
|
Miguel Urco
|
r18 | ||
|
Fiorella Quino
|
r108 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Fiorella Quino
|
r108 | def campaign_import(request, id_camp): | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r108 | campaign = get_object_or_404(Campaign, pk=id_camp) | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r108 | if request.method == 'GET': | |
| file_form = UploadFileForm() | |||
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r108 | if request.method == 'POST': | |
| file_form = UploadFileForm(request.POST, request.FILES) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r108 | if file_form.is_valid(): | |
|
Juan C. Espinoza
|
r316 | new_camp = campaign.dict_to_parms( | |
| json.load(request.FILES['file']), CONF_MODELS) | |||
| messages.success( | |||
| request, "Parameters imported from: '%s'." % request.FILES['file'].name) | |||
|
Fiorella Quino
|
r266 | return redirect(new_camp.get_absolute_url_edit()) | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r108 | messages.error(request, "Could not import parameters from file") | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r108 | kwargs = {} | |
| kwargs['title'] = 'Campaign' | |||
| kwargs['form'] = file_form | |||
| kwargs['suptitle'] = 'Importing file' | |||
| kwargs['button'] = 'Import' | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_campaigns'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r108 | return render(request, 'campaign_import.html', kwargs) | |
|
Miguel Urco
|
r13 | def experiments(request): | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | page = request.GET.get('page') | |
| order = ('location',) | |||
| filters = request.GET.copy() | |||
|
Juan C. Espinoza
|
r316 | if 'my experiments' in filters: | |
| filters.pop('my experiments', None) | |||
| filters['mine'] = request.user.id | |||
|
Juan C. Espinoza
|
r138 | kwargs = get_paginator(Experiment, page, order, filters) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | fields = ['tags', 'template'] | |
| if request.user.is_authenticated: | |||
| fields.append('my experiments') | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | form = FilterForm(initial=request.GET, extra_fields=fields) | |
| kwargs['keys'] = ['name', 'radar_system', | |||
| 'start_time', 'end_time', 'actions'] | |||
|
Miguel Urco
|
r13 | kwargs['title'] = 'Experiment' | |
| kwargs['suptitle'] = 'List' | |||
|
Juan C. Espinoza
|
r196 | kwargs['no_sidebar'] = True | |
|
Juan C. Espinoza
|
r138 | kwargs['form'] = form | |
|
Juan C. Espinoza
|
r316 | kwargs['add_url'] = reverse('url_add_experiment') | |
| filters = request.GET.copy() | |||
|
Juan C. Espinoza
|
r138 | filters.pop('page', None) | |
|
Juan C. Espinoza
|
r172 | kwargs['q'] = urlencode(filters) | |
|
Juan C. Espinoza
|
r320 | kwargs['menu_experiments'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | return render(request, 'base_list.html', kwargs) | |
|
Miguel Urco
|
r13 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Miguel Urco
|
r13 | def experiment(request, id_exp): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r20 | experiment = get_object_or_404(Experiment, pk=id_exp) | |
|
Fiorella Quino
|
r266 | ||
|
Juan C. Espinoza
|
r316 | configurations = Configuration.objects.filter( | |
| experiment=experiment, type=0) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | kwargs = {} | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | kwargs['experiment_keys'] = ['template', 'radar_system', | |
| 'name', 'freq', 'start_time', 'end_time'] | |||
|
Miguel Urco
|
r13 | kwargs['experiment'] = experiment | |
|
Juan C. Espinoza
|
r316 | kwargs['configuration_keys'] = ['name', 'device__ip_address', | |
| 'device__port_address', 'device__status'] | |||
|
Juan C. Espinoza
|
r91 | kwargs['configurations'] = configurations | |
|
Miguel Urco
|
r13 | kwargs['title'] = 'Experiment' | |
| kwargs['suptitle'] = 'Details' | |||
|
Juan C. Espinoza
|
r45 | kwargs['button'] = 'Add Configuration' | |
|
Juan C. Espinoza
|
r320 | kwargs['menu_experiments'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r85 | ###### SIDEBAR ###### | |
| kwargs.update(sidebar(experiment=experiment)) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | return render(request, 'experiment.html', kwargs) | |
|
Juan C. Espinoza
|
r85 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Juan C. Espinoza
|
r79 | def experiment_new(request, id_camp=None): | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if not is_developer(request.user): | |
| messages.error( | |||
| request, 'Developer required, to create new Experiments') | |||
| return redirect('index') | |||
|
Juan C. Espinoza
|
r85 | kwargs = {} | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | if request.method == 'GET': | |
|
Juan C. Espinoza
|
r85 | if 'template' in request.GET: | |
|
Juan C. Espinoza
|
r316 | if request.GET['template'] == '0': | |
| form = NewForm(initial={'create_from': 2}, | |||
|
Juan C. Espinoza
|
r85 | template_choices=Experiment.objects.filter(template=True).values_list('id', 'name')) | |
| else: | |||
| kwargs['button'] = 'Create' | |||
|
Juan C. Espinoza
|
r316 | kwargs['configurations'] = Configuration.objects.filter( | |
| experiment=request.GET['template']) | |||
| kwargs['configuration_keys'] = ['name', 'device__name', | |||
| 'device__ip_address', 'device__port_address'] | |||
| exp = Experiment.objects.get(pk=request.GET['template']) | |||
|
Juan C. Espinoza
|
r172 | form = ExperimentForm(instance=exp, | |
|
Fiorella Quino
|
r266 | initial={'name': '{}_{:%y%m%d}'.format(exp.name, datetime.now()), | |
|
Juan C. Espinoza
|
r172 | 'template': False}) | |
|
Juan C. Espinoza
|
r85 | elif 'blank' in request.GET: | |
| kwargs['button'] = 'Create' | |||
| form = ExperimentForm() | |||
| else: | |||
| form = NewForm() | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r6 | if request.method == 'POST': | |
|
Juan C. Espinoza
|
r138 | form = ExperimentForm(request.POST) | |
|
Juan C. Espinoza
|
r6 | if form.is_valid(): | |
|
Juan C. Espinoza
|
r316 | experiment = form.save(commit=False) | |
| experiment.author = request.user | |||
| experiment.save() | |||
|
Juan C. Espinoza
|
r85 | ||
| if 'template' in request.GET: | |||
|
Juan C. Espinoza
|
r316 | configurations = Configuration.objects.filter( | |
| experiment=request.GET['template'], type=0) | |||
|
Juan C. Espinoza
|
r85 | for conf in configurations: | |
| conf.clone(experiment=experiment, template=False) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | return redirect('url_experiment', id_exp=experiment.id) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | kwargs['form'] = form | |
|
Juan C. Espinoza
|
r6 | kwargs['title'] = 'Experiment' | |
| kwargs['suptitle'] = 'New' | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_experiments'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | return render(request, 'experiment_edit.html', kwargs) | |
|
Juan C. Espinoza
|
r6 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r19 | def experiment_edit(request, id_exp): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r20 | experiment = get_object_or_404(Experiment, pk=id_exp) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | if request.method == 'GET': | |
| form = ExperimentForm(instance=experiment) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'POST': | |
|
Miguel Urco
|
r13 | form = ExperimentForm(request.POST, instance=experiment) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r6 | if form.is_valid(): | |
|
Miguel Urco
|
r13 | experiment = form.save() | |
| return redirect('url_experiment', id_exp=experiment.id) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | kwargs = {} | |
| kwargs['form'] = form | |||
| kwargs['title'] = 'Experiment' | |||
| kwargs['suptitle'] = 'Edit' | |||
| kwargs['button'] = 'Update' | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_experiments'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | return render(request, 'experiment_edit.html', kwargs) | |
|
Juan C. Espinoza
|
r2 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r19 | def experiment_delete(request, id_exp): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r20 | experiment = get_object_or_404(Experiment, pk=id_exp) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'POST': | |
|
Juan C. Espinoza
|
r320 | if is_developer(request.user): | |
|
Juan C. Espinoza
|
r91 | for conf in Configuration.objects.filter(experiment=experiment): | |
|
Juan C. Espinoza
|
r172 | conf.delete() | |
|
Miguel Urco
|
r18 | experiment.delete() | |
|
Juan C. Espinoza
|
r85 | return redirect('url_experiments') | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r91 | messages.error(request, 'Not enough permission to delete this object') | |
|
Juan C. Espinoza
|
r172 | return redirect(experiment.get_absolute_url()) | |
|
Juan C. Espinoza
|
r91 | kwargs = { | |
|
Juan C. Espinoza
|
r316 | 'title': 'Delete', | |
| 'suptitle': 'Experiment', | |||
| 'object': experiment, | |||
| 'delete': True | |||
| } | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r91 | return render(request, 'confirm.html', kwargs) | |
|
Miguel Urco
|
r18 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Fiorella Quino
|
r100 | def experiment_export(request, id_exp): | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r100 | experiment = get_object_or_404(Experiment, pk=id_exp) | |
|
Juan C. Espinoza
|
r172 | content = experiment.parms_to_dict() | |
|
Fiorella Quino
|
r100 | content_type = 'application/json' | |
|
Juan C. Espinoza
|
r316 | filename = '%s_%s.json' % (experiment.name, experiment.id) | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r100 | response = HttpResponse(content_type=content_type) | |
|
Juan C. Espinoza
|
r316 | response['Content-Disposition'] = 'attachment; filename="%s"' % filename | |
|
Fiorella Quino
|
r266 | response.write(json.dumps(content, indent=2)) | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r100 | return response | |
|
Fiorella Quino
|
r211 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Fiorella Quino
|
r108 | def experiment_import(request, id_exp): | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | experiment = get_object_or_404(Experiment, pk=id_exp) | |
|
Fiorella Quino
|
r108 | configurations = Configuration.objects.filter(experiment=experiment) | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r108 | if request.method == 'GET': | |
| file_form = UploadFileForm() | |||
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r108 | if request.method == 'POST': | |
| file_form = UploadFileForm(request.POST, request.FILES) | |||
|
Fiorella Quino
|
r243 | ||
|
Fiorella Quino
|
r108 | if file_form.is_valid(): | |
|
Juan C. Espinoza
|
r316 | new_exp = experiment.dict_to_parms( | |
| json.load(request.FILES['file']), CONF_MODELS) | |||
| messages.success( | |||
| request, "Parameters imported from: '%s'." % request.FILES['file'].name) | |||
|
Fiorella Quino
|
r266 | return redirect(new_exp.get_absolute_url_edit()) | |
|
Fiorella Quino
|
r108 | ||
| messages.error(request, "Could not import parameters from file") | |||
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r108 | kwargs = {} | |
| kwargs['title'] = 'Experiment' | |||
| kwargs['form'] = file_form | |||
| kwargs['suptitle'] = 'Importing file' | |||
| kwargs['button'] = 'Import' | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_experiments'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r108 | kwargs.update(sidebar(experiment=experiment)) | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r108 | return render(request, 'experiment_import.html', kwargs) | |
|
Fiorella Quino
|
r100 | ||
|
Fiorella Quino
|
r211 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Juan C. Espinoza
|
r240 | def experiment_start(request, id_exp): | |
|
Fiorella Quino
|
r241 | ||
|
Fiorella Quino
|
r266 | exp = get_object_or_404(Experiment, pk=id_exp) | |
|
Fiorella Quino
|
r251 | ||
|
Fiorella Quino
|
r252 | if exp.status == 2: | |
|
Fiorella Quino
|
r266 | messages.warning(request, 'Experiment {} already runnnig'.format(exp)) | |
|
Juan C. Espinoza
|
r240 | else: | |
|
Fiorella Quino
|
r266 | exp.status = exp.start() | |
|
Juan C. Espinoza
|
r316 | if exp.status == 0: | |
|
Juan C. Espinoza
|
r240 | messages.error(request, 'Experiment {} not start'.format(exp)) | |
|
Juan C. Espinoza
|
r316 | if exp.status == 2: | |
|
Juan C. Espinoza
|
r240 | messages.success(request, 'Experiment {} started'.format(exp)) | |
|
Fiorella Quino
|
r266 | ||
|
Fiorella Quino
|
r252 | exp.save() | |
|
Juan C. Espinoza
|
r240 | ||
| return redirect(exp.get_absolute_url()) | |||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Juan C. Espinoza
|
r240 | def experiment_stop(request, id_exp): | |
|
Fiorella Quino
|
r241 | ||
|
Juan C. Espinoza
|
r240 | exp = get_object_or_404(Experiment, pk=id_exp) | |
|
Fiorella Quino
|
r254 | ||
|
Juan C. Espinoza
|
r240 | if exp.status == 2: | |
|
Fiorella Quino
|
r266 | exp.status = exp.stop() | |
|
Juan C. Espinoza
|
r240 | exp.save() | |
|
Fiorella Quino
|
r266 | messages.success(request, 'Experiment {} stopped'.format(exp)) | |
|
Juan C. Espinoza
|
r240 | else: | |
|
Fiorella Quino
|
r241 | messages.error(request, 'Experiment {} not running'.format(exp)) | |
|
Juan C. Espinoza
|
r240 | ||
| return redirect(exp.get_absolute_url()) | |||
|
Fiorella Quino
|
r266 | def experiment_status(request, id_exp): | |
| exp = get_object_or_404(Experiment, pk=id_exp) | |||
| exp.get_status() | |||
| return redirect(exp.get_absolute_url()) | |||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Juan C. Espinoza
|
r106 | def experiment_mix(request, id_exp): | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | experiment = get_object_or_404(Experiment, pk=id_exp) | |
|
Juan C. Espinoza
|
r316 | rc_confs = [conf for conf in RCConfiguration.objects.filter( | |
| experiment=id_exp, | |||
| type=0, | |||
| mix=False)] | |||
| if len(rc_confs) < 2: | |||
| messages.warning( | |||
| request, 'You need at least two RC Configurations to make a mix') | |||
|
Juan C. Espinoza
|
r106 | return redirect(experiment.get_absolute_url()) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r320 | mix_confs = RCConfiguration.objects.filter(experiment=id_exp, mix=True, type=0) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | if mix_confs: | |
| mix = mix_confs[0] | |||
| else: | |||
| mix = RCConfiguration(experiment=experiment, | |||
| device=rc_confs[0].device, | |||
| ipp=rc_confs[0].ipp, | |||
| clock_in=rc_confs[0].clock_in, | |||
| clock_divider=rc_confs[0].clock_divider, | |||
|
Juan C. Espinoza
|
r172 | mix=True, | |
|
Juan C. Espinoza
|
r106 | parameters='') | |
| mix.save() | |||
|
Fiorella Quino
|
r241 | ||
|
Juan C. Espinoza
|
r106 | line_type = RCLineType.objects.get(name='mix') | |
| for i in range(len(rc_confs[0].get_lines())): | |||
| line = RCLine(rc_configuration=mix, line_type=line_type, channel=i) | |||
|
Fiorella Quino
|
r241 | line.save() | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r241 | initial = {'name': mix.name, | |
| 'result': parse_mix_result(mix.parameters), | |||
| 'delay': 0, | |||
|
Juan C. Espinoza
|
r316 | 'mask': [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15] | |
|
Juan C. Espinoza
|
r106 | } | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'GET': | |
|
Juan C. Espinoza
|
r106 | form = RCMixConfigurationForm(confs=rc_confs, initial=initial) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'POST': | |
|
Juan C. Espinoza
|
r106 | result = mix.parameters | |
| if '{}|'.format(request.POST['experiment']) in result: | |||
| messages.error(request, 'Configuration already added') | |||
| else: | |||
|
Juan C. Espinoza
|
r112 | if 'operation' in request.POST: | |
| operation = MIX_OPERATIONS[request.POST['operation']] | |||
| else: | |||
|
Juan C. Espinoza
|
r116 | operation = ' ' | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r112 | mode = MIX_MODES[request.POST['mode']] | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | if result: | |
|
Juan C. Espinoza
|
r112 | result = '{}-{}|{}|{}|{}|{}'.format(mix.parameters, | |
|
Juan C. Espinoza
|
r316 | request.POST['experiment'], | |
| mode, | |||
| operation, | |||
| float( | |||
| request.POST['delay']), | |||
| parse_mask( | |||
| request.POST.getlist('mask')) | |||
| ) | |||
|
Juan C. Espinoza
|
r106 | else: | |
|
Juan C. Espinoza
|
r112 | result = '{}|{}|{}|{}|{}'.format(request.POST['experiment'], | |
|
Juan C. Espinoza
|
r316 | mode, | |
| operation, | |||
| float(request.POST['delay']), | |||
| parse_mask( | |||
| request.POST.getlist('mask')) | |||
| ) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | mix.parameters = result | |
| mix.save() | |||
| mix.update_pulses() | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | initial['result'] = parse_mix_result(result) | |
| initial['name'] = mix.name | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | form = RCMixConfigurationForm(initial=initial, confs=rc_confs) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | kwargs = { | |
|
Juan C. Espinoza
|
r316 | 'title': 'Experiment', | |
| 'suptitle': 'Mix Configurations', | |||
| 'form': form, | |||
| 'extra_button': 'Delete', | |||
| 'button': 'Add', | |||
| 'cancel': 'Back', | |||
| 'previous': experiment.get_absolute_url(), | |||
| 'id_exp': id_exp, | |||
|
Juan C. Espinoza
|
r106 | ||
|
Juan C. Espinoza
|
r316 | } | |
|
Juan C. Espinoza
|
r320 | kwargs['menu_experiments'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | return render(request, 'experiment_mix.html', kwargs) | |
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Juan C. Espinoza
|
r106 | def experiment_mix_delete(request, id_exp): | |
|
Juan C. Espinoza
|
r172 | ||
| r311 | conf = RCConfiguration.objects.get(experiment=id_exp, mix=True, type=0) | ||
|
Juan C. Espinoza
|
r106 | values = conf.parameters.split('-') | |
| conf.parameters = '-'.join(values[:-1]) | |||
| conf.save() | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | return redirect('url_mix_experiment', id_exp=id_exp) | |
|
Fiorella Quino
|
r241 | def experiment_summary(request, id_exp): | |
|
Fiorella Quino
|
r214 | ||
|
Juan C. Espinoza
|
r316 | experiment = get_object_or_404(Experiment, pk=id_exp) | |
| configurations = Configuration.objects.filter( | |||
| experiment=experiment, type=0) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r151 | kwargs = {} | |
|
Juan C. Espinoza
|
r316 | kwargs['experiment_keys'] = ['radar_system', | |
| 'name', 'freq', 'start_time', 'end_time'] | |||
|
Fiorella Quino
|
r151 | kwargs['experiment'] = experiment | |
|
Juan C. Espinoza
|
r239 | kwargs['configurations'] = [] | |
|
Fiorella Quino
|
r151 | kwargs['title'] = 'Experiment Summary' | |
| kwargs['suptitle'] = 'Details' | |||
| kwargs['button'] = 'Verify Parameters' | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | c_vel = 3.0*(10**8) # m/s | |
| ope_freq = experiment.freq*(10**6) # 1/s | |||
| radar_lambda = c_vel/ope_freq # m | |||
|
Fiorella Quino
|
r266 | kwargs['radar_lambda'] = radar_lambda | |
|
Juan C. Espinoza
|
r316 | ipp = None | |
| nsa = 1 | |||
|
Fiorella Quino
|
r266 | code_id = 0 | |
| tx_line = {} | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | for configuration in configurations.filter(device__device_type__name = 'rc'): | |
|
Fiorella Quino
|
r266 | ||
|
Juan C. Espinoza
|
r316 | if configuration.mix: | |
| continue | |||
| conf = {'conf': configuration} | |||
| conf['keys'] = [] | |||
| conf['NTxs'] = configuration.ntx | |||
| conf['keys'].append('NTxs') | |||
| ipp = configuration.ipp | |||
| conf['IPP'] = ipp | |||
| conf['keys'].append('IPP') | |||
| lines = configuration.get_lines(line_type__name='tx') | |||
| for tx_line in lines: | |||
| tx_params = json.loads(tx_line.params) | |||
| conf[tx_line.get_name()] = '{} Km'.format(tx_params['pulse_width']) | |||
| conf['keys'].append(tx_line.get_name()) | |||
| delays = tx_params['delays'] | |||
| if delays not in ('', '0'): | |||
| n = len(delays.split(',')) | |||
| taus = '{} Taus: {}'.format(n, delays) | |||
| else: | |||
| taus = '-' | |||
| conf['Taus ({})'.format(tx_line.get_name())] = taus | |||
| conf['keys'].append('Taus ({})'.format(tx_line.get_name())) | |||
| for code_line in configuration.get_lines(line_type__name='codes'): | |||
| code_params = json.loads(code_line.params) | |||
| code_id = code_params['code'] | |||
| if tx_line.pk == int(code_params['TX_ref']): | |||
| conf['Code ({})'.format(tx_line.get_name())] = '{}:{}'.format(RCLineCode.objects.get(pk=code_params['code']), | |||
| '-'.join(code_params['codes'])) | |||
| conf['keys'].append('Code ({})'.format(tx_line.get_name())) | |||
| for windows_line in configuration.get_lines(line_type__name='windows'): | |||
| win_params = json.loads(windows_line.params) | |||
| if tx_line.pk == int(win_params['TX_ref']): | |||
| windows = '' | |||
| nsa = win_params['params'][0]['number_of_samples'] | |||
| for i, params in enumerate(win_params['params']): | |||
| windows += 'W{}: Ho={first_height} km DH={resolution} km NSA={number_of_samples}<br>'.format( | |||
| i, **params) | |||
| conf['Window'] = mark_safe(windows) | |||
| conf['keys'].append('Window') | |||
| kwargs['configurations'].append(conf) | |||
| for configuration in configurations.filter(device__device_type__name = 'jars'): | |||
| conf = {'conf': configuration} | |||
| conf['keys'] = [] | |||
| conf['Type of Data'] = EXPERIMENT_TYPE[configuration.exp_type][1] | |||
| conf['keys'].append('Type of Data') | |||
| channels_number = configuration.channels_number | |||
| exp_type = configuration.exp_type | |||
| fftpoints = configuration.fftpoints | |||
| filter_parms = json.loads(configuration.filter_parms) | |||
| spectral_number = configuration.spectral_number | |||
| acq_profiles = configuration.acq_profiles | |||
| cohe_integr = configuration.cohe_integr | |||
| profiles_block = configuration.profiles_block | |||
| conf['Num of Profiles'] = acq_profiles | |||
| conf['keys'].append('Num of Profiles') | |||
| conf['Prof per Block'] = profiles_block | |||
| conf['keys'].append('Prof per Block') | |||
| conf['Blocks per File'] = configuration.raw_data_blocks | |||
| conf['keys'].append('Blocks per File') | |||
| if exp_type == 0: # Short | |||
| bytes_ = 2 | |||
| b = nsa*2*bytes_*channels_number | |||
| else: # Float | |||
| bytes_ = 4 | |||
| channels = channels_number + spectral_number | |||
| b = nsa*2*bytes_*fftpoints*channels | |||
| codes_num = 7 | |||
| if code_id == 2: | |||
|
Fiorella Quino
|
r266 | codes_num = 7 | |
|
Juan C. Espinoza
|
r316 | elif code_id == 12: | |
| codes_num = 15 | |||
| #Jars filter values: | |||
| clock = float(filter_parms['clock']) | |||
| filter_2 = int(filter_parms['cic_2']) | |||
| filter_5 = int(filter_parms['cic_5']) | |||
| filter_fir = int(filter_parms['fir']) | |||
| Fs_MHz = clock/(filter_2*filter_5*filter_fir) | |||
| #Jars values: | |||
| if ipp is not None: | |||
| IPP_units = ipp/0.15*Fs_MHz | |||
| IPP_us = IPP_units / Fs_MHz | |||
| IPP_s = IPP_units / (Fs_MHz * (10**6)) | |||
| Ts = 1/(Fs_MHz*(10**6)) | |||
| Va = radar_lambda/(4*Ts*cohe_integr) | |||
| rate_bh = ((nsa-codes_num)*channels_number*2 * | |||
| bytes_/IPP_us)*(36*(10**8)/cohe_integr) | |||
| rate_gh = rate_bh/(1024*1024*1024) | |||
| conf['Time per Block'] = IPP_s * profiles_block * cohe_integr | |||
| conf['keys'].append('Time per Block') | |||
| conf['Acq time'] = IPP_s * acq_profiles | |||
| conf['keys'].append('Acq time') | |||
| conf['Data rate'] = str(rate_gh)+" (GB/h)" | |||
| conf['keys'].append('Data rate') | |||
| conf['Va (m/s)'] = Va | |||
| conf['keys'].append('Va (m/s)') | |||
| conf['Vrange (m/s)'] = 3/(2*IPP_s*cohe_integr) | |||
| conf['keys'].append('Vrange (m/s)') | |||
| kwargs['configurations'].append(conf) | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_experiments'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r151 | ###### SIDEBAR ###### | |
| kwargs.update(sidebar(experiment=experiment)) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r151 | return render(request, 'experiment_summary.html', kwargs) | |
|
Fiorella Quino
|
r211 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Juan C. Espinoza
|
r157 | def experiment_verify(request, id_exp): | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | experiment = get_object_or_404(Experiment, pk=id_exp) | |
|
Fiorella Quino
|
r266 | experiment_data = experiment.parms_to_dict() | |
|
Juan C. Espinoza
|
r316 | configurations = Configuration.objects.filter( | |
| experiment=experiment, type=0) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r157 | kwargs = {} | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | kwargs['experiment_keys'] = ['template', | |
| 'radar_system', 'name', 'start_time', 'end_time'] | |||
|
Juan C. Espinoza
|
r157 | kwargs['experiment'] = experiment | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | kwargs['configuration_keys'] = ['name', 'device__ip_address', | |
| 'device__port_address', 'device__status'] | |||
|
Juan C. Espinoza
|
r157 | kwargs['configurations'] = configurations | |
| kwargs['experiment_data'] = experiment_data | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r157 | kwargs['title'] = 'Verify Experiment' | |
| kwargs['suptitle'] = 'Parameters' | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r157 | kwargs['button'] = 'Update' | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r157 | jars_conf = False | |
|
Juan C. Espinoza
|
r316 | rc_conf = False | |
| dds_conf = False | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r157 | for configuration in configurations: | |
| #-------------------- JARS -----------------------: | |||
| if configuration.device.device_type.name == 'jars': | |||
| jars_conf = True | |||
|
Fiorella Quino
|
r229 | jars = configuration | |
|
Juan C. Espinoza
|
r316 | kwargs['jars_conf'] = jars_conf | |
| filter_parms = json.loads(jars.filter_parms) | |||
|
Juan C. Espinoza
|
r157 | kwargs['filter_parms'] = filter_parms | |
| #--Sampling Frequency | |||
|
Juan C. Espinoza
|
r316 | clock = filter_parms['clock'] | |
| filter_2 = filter_parms['cic_2'] | |||
| filter_5 = filter_parms['cic_5'] | |||
| filter_fir = filter_parms['fir'] | |||
|
Juan C. Espinoza
|
r157 | samp_freq_jars = clock/filter_2/filter_5/filter_fir | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r157 | kwargs['samp_freq_jars'] = samp_freq_jars | |
|
Juan C. Espinoza
|
r316 | kwargs['jars'] = configuration | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r157 | #--------------------- RC ----------------------: | |
|
Juan C. Espinoza
|
r239 | if configuration.device.device_type.name == 'rc' and not configuration.mix: | |
|
Juan C. Espinoza
|
r157 | rc_conf = True | |
|
Fiorella Quino
|
r229 | rc = configuration | |
|
Fiorella Quino
|
r241 | ||
|
Juan C. Espinoza
|
r157 | rc_parms = configuration.parms_to_dict() | |
|
Fiorella Quino
|
r241 | ||
|
Juan C. Espinoza
|
r239 | win_lines = rc.get_lines(line_type__name='windows') | |
| if win_lines: | |||
| dh = json.loads(win_lines[0].params)['params'][0]['resolution'] | |||
|
Juan C. Espinoza
|
r157 | #--Sampling Frequency | |
|
Juan C. Espinoza
|
r172 | samp_freq_rc = 0.15/dh | |
|
Juan C. Espinoza
|
r157 | kwargs['samp_freq_rc'] = samp_freq_rc | |
|
Fiorella Quino
|
r241 | ||
|
Juan C. Espinoza
|
r239 | kwargs['rc_conf'] = rc_conf | |
|
Juan C. Espinoza
|
r316 | kwargs['rc'] = configuration | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r157 | #-------------------- DDS ----------------------: | |
| if configuration.device.device_type.name == 'dds': | |||
| dds_conf = True | |||
|
Fiorella Quino
|
r229 | dds = configuration | |
|
Juan C. Espinoza
|
r157 | dds_parms = configuration.parms_to_dict() | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r157 | kwargs['dds_conf'] = dds_conf | |
|
Juan C. Espinoza
|
r316 | kwargs['dds'] = configuration | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r157 | #------------Validation------------: | |
| #Clock | |||
| if dds_conf and rc_conf and jars_conf: | |||
|
Fiorella Quino
|
r266 | if float(filter_parms['clock']) != float(rc_parms['configurations']['byId'][str(rc.pk)]['clock_in']) and float(rc_parms['configurations']['byId'][str(rc.pk)]['clock_in']) != float(dds_parms['configurations']['byId'][str(dds.pk)]['clock']): | |
|
Juan C. Espinoza
|
r157 | messages.warning(request, "Devices don't have the same clock.") | |
| elif rc_conf and jars_conf: | |||
|
Fiorella Quino
|
r266 | if float(filter_parms['clock']) != float(rc_parms['configurations']['byId'][str(rc.pk)]['clock_in']): | |
|
Juan C. Espinoza
|
r157 | messages.warning(request, "Devices don't have the same clock.") | |
| elif rc_conf and dds_conf: | |||
|
Fiorella Quino
|
r266 | if float(rc_parms['configurations']['byId'][str(rc.pk)]['clock_in']) != float(dds_parms['configurations']['byId'][str(dds.pk)]['clock']): | |
|
Juan C. Espinoza
|
r157 | messages.warning(request, "Devices don't have the same clock.") | |
|
Fiorella Quino
|
r266 | if float(samp_freq_rc) != float(dds_parms['configurations']['byId'][str(dds.pk)]['frequencyA']): | |
|
Juan C. Espinoza
|
r316 | messages.warning( | |
| request, "Devices don't have the same Frequency A.") | |||
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r229 | #------------POST METHOD------------: | |
| if request.method == 'POST': | |||
| if request.POST['suggest_clock']: | |||
| try: | |||
| suggest_clock = float(request.POST['suggest_clock']) | |||
| except: | |||
| messages.warning(request, "Invalid value in CLOCK IN.") | |||
| return redirect('url_verify_experiment', id_exp=experiment.id) | |||
| else: | |||
| suggest_clock = "" | |||
| if suggest_clock: | |||
| if rc_conf: | |||
| rc.clock_in = suggest_clock | |||
| rc.save() | |||
| if jars_conf: | |||
|
Juan C. Espinoza
|
r316 | filter_parms = jars.filter_parms | |
| filter_parms = ast.literal_eval(filter_parms) | |||
|
Fiorella Quino
|
r229 | filter_parms['clock'] = suggest_clock | |
| jars.filter_parms = json.dumps(filter_parms) | |||
| jars.save() | |||
| kwargs['filter_parms'] = filter_parms | |||
| if dds_conf: | |||
| dds.clock = suggest_clock | |||
| dds.save() | |||
| if request.POST['suggest_frequencyA']: | |||
| try: | |||
| suggest_frequencyA = float(request.POST['suggest_frequencyA']) | |||
| except: | |||
| messages.warning(request, "Invalid value in FREQUENCY A.") | |||
| return redirect('url_verify_experiment', id_exp=experiment.id) | |||
| else: | |||
| suggest_frequencyA = "" | |||
| if suggest_frequencyA: | |||
| if jars_conf: | |||
|
Juan C. Espinoza
|
r316 | filter_parms = jars.filter_parms | |
| filter_parms = ast.literal_eval(filter_parms) | |||
|
Fiorella Quino
|
r229 | filter_parms['fch'] = suggest_frequencyA | |
| jars.filter_parms = json.dumps(filter_parms) | |||
| jars.save() | |||
| kwargs['filter_parms'] = filter_parms | |||
| if dds_conf: | |||
| dds.frequencyA_Mhz = request.POST['suggest_frequencyA'] | |||
| dds.save() | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r320 | kwargs['menu_experiments'] = 'active' | |
|
Juan C. Espinoza
|
r157 | kwargs.update(sidebar(experiment=experiment)) | |
| return render(request, 'experiment_verify.html', kwargs) | |||
|
Fiorella Quino
|
r151 | ||
|
Juan C. Espinoza
|
r106 | def parse_mix_result(s): | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | values = s.split('-') | |
|
Juan C. Espinoza
|
r172 | html = 'EXP MOD OPE DELAY MASK\r\n' | |
|
Juan C. Espinoza
|
r112 | if not values or values[0] in ('', ' '): | |
| return mark_safe(html) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | for i, value in enumerate(values): | |
| if not value: | |||
| continue | |||
|
Juan C. Espinoza
|
r112 | pk, mode, operation, delay, mask = value.split('|') | |
|
Juan C. Espinoza
|
r106 | conf = RCConfiguration.objects.get(pk=pk) | |
|
Juan C. Espinoza
|
r316 | if i == 0: | |
|
Juan C. Espinoza
|
r172 | html += '{:20.18}{:3}{:4}{:9}km{:>6}\r\n'.format( | |
|
Juan C. Espinoza
|
r316 | conf.name, | |
| mode, | |||
| ' ', | |||
| delay, | |||
| mask) | |||
|
Juan C. Espinoza
|
r106 | else: | |
|
Juan C. Espinoza
|
r112 | html += '{:20.18}{:3}{:4}{:9}km{:>6}\r\n'.format( | |
|
Juan C. Espinoza
|
r316 | conf.name, | |
| mode, | |||
| operation, | |||
| delay, | |||
| mask) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | return mark_safe(html) | |
|
Juan C. Espinoza
|
r316 | ||
|
Juan C. Espinoza
|
r106 | def parse_mask(l): | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | values = [] | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | for x in range(16): | |
|
Juan C. Espinoza
|
r106 | if '{}'.format(x) in l: | |
| values.append(1) | |||
| else: | |||
| values.append(0) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | values.reverse() | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | return int(''.join([str(x) for x in values]), 2) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | ||
|
Miguel Urco
|
r13 | def dev_confs(request): | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | page = request.GET.get('page') | |
|
Juan C. Espinoza
|
r316 | order = ('programmed_date', ) | |
|
Juan C. Espinoza
|
r138 | filters = request.GET.copy() | |
|
Juan C. Espinoza
|
r316 | if 'my configurations' in filters: | |
| filters.pop('my configurations', None) | |||
| filters['mine'] = request.user.id | |||
|
Juan C. Espinoza
|
r138 | kwargs = get_paginator(Configuration, page, order, filters) | |
|
Juan C. Espinoza
|
r316 | fields = ['tags', 'template', 'historical'] | |
| if request.user.is_authenticated: | |||
| fields.append('my configurations') | |||
| form = FilterForm(initial=request.GET, extra_fields=fields) | |||
| kwargs['keys'] = ['name', 'experiment', | |||
| 'type', 'programmed_date', 'actions'] | |||
|
Miguel Urco
|
r14 | kwargs['title'] = 'Configuration' | |
|
Miguel Urco
|
r13 | kwargs['suptitle'] = 'List' | |
|
Juan C. Espinoza
|
r196 | kwargs['no_sidebar'] = True | |
|
Juan C. Espinoza
|
r172 | kwargs['form'] = form | |
|
Juan C. Espinoza
|
r316 | kwargs['add_url'] = reverse('url_add_dev_conf', args=[0]) | |
| filters = request.GET.copy() | |||
|
Juan C. Espinoza
|
r138 | filters.pop('page', None) | |
|
Juan C. Espinoza
|
r172 | kwargs['q'] = urlencode(filters) | |
|
Juan C. Espinoza
|
r320 | kwargs['menu_configurations'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | return render(request, 'base_list.html', kwargs) | |
|
Miguel Urco
|
r13 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Miguel Urco
|
r13 | def dev_conf(request, id_conf): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r20 | conf = get_object_or_404(Configuration, pk=id_conf) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r79 | return redirect(conf.get_absolute_url()) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r79 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Juan C. Espinoza
|
r79 | def dev_conf_new(request, id_exp=0, id_dev=0): | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if not is_developer(request.user): | |
| messages.error( | |||
| request, 'Developer required, to create new configurations') | |||
| return redirect('index') | |||
|
Juan C. Espinoza
|
r79 | initial = {} | |
|
Juan C. Espinoza
|
r106 | kwargs = {} | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if id_exp != 0: | |
|
Juan C. Espinoza
|
r79 | initial['experiment'] = id_exp | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if id_dev != 0: | |
|
Juan C. Espinoza
|
r79 | initial['device'] = id_dev | |
|
Miguel Urco
|
r13 | ||
| if request.method == 'GET': | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r106 | if id_dev: | |
| kwargs['button'] = 'Create' | |||
|
Juan C. Espinoza
|
r79 | device = Device.objects.get(pk=id_dev) | |
| DevConfForm = CONF_FORMS[device.device_type.name] | |||
|
Juan C. Espinoza
|
r172 | initial['name'] = request.GET['name'] | |
| form = DevConfForm(initial=initial) | |||
|
Juan C. Espinoza
|
r106 | else: | |
| if 'template' in request.GET: | |||
|
Juan C. Espinoza
|
r316 | if request.GET['template'] == '0': | |
| choices = [(conf.pk, '{}'.format(conf)) | |||
| for conf in Configuration.objects.filter(template=True)] | |||
| form = NewForm(initial={'create_from': 2}, | |||
|
Juan C. Espinoza
|
r121 | template_choices=choices) | |
|
Juan C. Espinoza
|
r106 | else: | |
|
Juan C. Espinoza
|
r172 | kwargs['button'] = 'Create' | |
|
Juan C. Espinoza
|
r316 | conf = Configuration.objects.get( | |
| pk=request.GET['template']) | |||
|
Juan C. Espinoza
|
r119 | id_dev = conf.device.pk | |
|
Juan C. Espinoza
|
r106 | DevConfForm = CONF_FORMS[conf.device.device_type.name] | |
|
Juan C. Espinoza
|
r172 | form = DevConfForm(instance=conf, | |
|
Fiorella Quino
|
r266 | initial={'name': '{}_{:%y%m%d}'.format(conf.name, datetime.now()), | |
|
Juan C. Espinoza
|
r116 | 'template': False, | |
|
Juan C. Espinoza
|
r316 | 'experiment': id_exp}) | |
|
Juan C. Espinoza
|
r106 | elif 'blank' in request.GET: | |
|
Juan C. Espinoza
|
r172 | kwargs['button'] = 'Create' | |
|
Juan C. Espinoza
|
r106 | form = ConfigurationForm(initial=initial) | |
| else: | |||
|
Juan C. Espinoza
|
r172 | form = NewForm() | |
|
Juan C. Espinoza
|
r6 | if request.method == 'POST': | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r79 | device = Device.objects.get(pk=request.POST['device']) | |
|
Miguel Urco
|
r47 | DevConfForm = CONF_FORMS[device.device_type.name] | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r79 | form = DevConfForm(request.POST) | |
|
Fiorella Quino
|
r122 | kwargs['button'] = 'Create' | |
|
Juan C. Espinoza
|
r6 | if form.is_valid(): | |
|
Juan C. Espinoza
|
r316 | conf = form.save(commit=False) | |
| conf.author = request.user | |||
| conf.save() | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if 'template' in request.GET and conf.device.device_type.name == 'rc': | |
| lines = RCLine.objects.filter( | |||
| rc_configuration=request.GET['template']) | |||
|
Juan C. Espinoza
|
r106 | for line in lines: | |
| line.clone(rc_configuration=conf) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r266 | new_lines = conf.get_lines() | |
| for line in new_lines: | |||
| line_params = json.loads(line.params) | |||
| if 'TX_ref' in line_params: | |||
| ref_line = RCLine.objects.get(pk=line_params['TX_ref']) | |||
|
Juan C. Espinoza
|
r316 | line_params['TX_ref'] = ['{}'.format( | |
| l.pk) for l in new_lines if l.get_name() == ref_line.get_name()][0] | |||
|
Fiorella Quino
|
r266 | line.params = json.dumps(line_params) | |
| line.save() | |||
|
Juan C. Espinoza
|
r172 | return redirect('url_dev_conf', id_conf=conf.pk) | |
|
Juan C. Espinoza
|
r79 | kwargs['id_exp'] = id_exp | |
|
Juan C. Espinoza
|
r6 | kwargs['form'] = form | |
|
Miguel Urco
|
r13 | kwargs['title'] = 'Configuration' | |
|
Juan C. Espinoza
|
r6 | kwargs['suptitle'] = 'New' | |
|
Juan C. Espinoza
|
r320 | kwargs['menu_configurations'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r99 | if id_dev != 0: | |
| device = Device.objects.get(pk=id_dev) | |||
|
Juan C. Espinoza
|
r119 | kwargs['device'] = device.device_type.name | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | return render(request, 'dev_conf_edit.html', kwargs) | |
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r19 | def dev_conf_edit(request, id_conf): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r20 | conf = get_object_or_404(Configuration, pk=id_conf) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | DevConfForm = CONF_FORMS[conf.device.device_type.name] | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'GET': | |
|
Juan C. Espinoza
|
r172 | form = DevConfForm(instance=conf) | |
|
Juan C. Espinoza
|
r316 | if request.method == 'POST': | |
|
Juan C. Espinoza
|
r172 | form = DevConfForm(request.POST, instance=conf) | |
|
Miguel Urco
|
r13 | if form.is_valid(): | |
| form.save() | |||
| return redirect('url_dev_conf', id_conf=id_conf) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r13 | kwargs = {} | |
| kwargs['form'] = form | |||
| kwargs['title'] = 'Device Configuration' | |||
| kwargs['suptitle'] = 'Edit' | |||
| kwargs['button'] = 'Update' | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_configurations'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r30 | ###### SIDEBAR ###### | |
|
Juan C. Espinoza
|
r85 | kwargs.update(sidebar(conf=conf)) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r91 | return render(request, '%s_conf_edit.html' % conf.device.device_type.name, kwargs) | |
|
Miguel Urco
|
r13 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r53 | def dev_conf_start(request, id_conf): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | conf = get_object_or_404(Configuration, pk=id_conf) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | if conf.start_device(): | |
| messages.success(request, conf.message) | |||
| else: | |||
| messages.error(request, conf.message) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r185 | #conf.status_device() | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | return redirect(conf.get_absolute_url()) | |
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r53 | def dev_conf_stop(request, id_conf): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r30 | conf = get_object_or_404(Configuration, pk=id_conf) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | if conf.stop_device(): | |
| messages.success(request, conf.message) | |||
| else: | |||
| messages.error(request, conf.message) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r185 | #conf.status_device() | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | return redirect(conf.get_absolute_url()) | |
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r326 | @login_required | |
|
Miguel Urco
|
r53 | def dev_conf_status(request, id_conf): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | conf = get_object_or_404(Configuration, pk=id_conf) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r326 | if conf.device.device_type.name == 'abs': | |
| abs = request.user.profile.abs_active | |||
| 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 | |||
| )) | |||
| ) | |||
| return redirect(conf.get_absolute_url()) | |||
|
Miguel Urco
|
r53 | if conf.status_device(): | |
| messages.success(request, conf.message) | |||
| else: | |||
| messages.error(request, conf.message) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | return redirect(conf.get_absolute_url()) | |
|
Miguel Urco
|
r30 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Fiorella Quino
|
r266 | def dev_conf_reset(request, id_conf): | |
| conf = get_object_or_404(Configuration, pk=id_conf) | |||
| if conf.reset_device(): | |||
| messages.success(request, conf.message) | |||
| else: | |||
| messages.error(request, conf.message) | |||
| return redirect(conf.get_absolute_url()) | |||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r30 | def dev_conf_write(request, id_conf): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r30 | conf = get_object_or_404(Configuration, pk=id_conf) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r185 | if conf.write_device(): | |
|
Fiorella Quino
|
r211 | messages.success(request, conf.message) | |
|
Juan C. Espinoza
|
r316 | if has_been_modified(conf): | |
| conf.clone(type=1, template=False) | |||
|
Miguel Urco
|
r53 | else: | |
| messages.error(request, conf.message) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r306 | return redirect(get_object_or_404(Configuration, pk=id_conf).get_absolute_url()) | |
|
Miguel Urco
|
r53 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r53 | def dev_conf_read(request, id_conf): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | conf = get_object_or_404(Configuration, pk=id_conf) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | DevConfForm = CONF_FORMS[conf.device.device_type.name] | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'GET': | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | parms = conf.read_device() | |
|
Juan C. Espinoza
|
r185 | #conf.status_device() | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | if not parms: | |
| messages.error(request, conf.message) | |||
| return redirect(conf.get_absolute_url()) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | form = DevConfForm(initial=parms, instance=conf) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'POST': | |
|
Miguel Urco
|
r53 | form = DevConfForm(request.POST, instance=conf) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | if form.is_valid(): | |
|
Miguel Urco
|
r57 | form.save() | |
| return redirect(conf.get_absolute_url()) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | messages.error(request, "Parameters could not be saved") | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | kwargs = {} | |
| kwargs['id_dev'] = conf.id | |||
| kwargs['form'] = form | |||
| kwargs['title'] = 'Device Configuration' | |||
| kwargs['suptitle'] = 'Parameters read from device' | |||
| kwargs['button'] = 'Save' | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | ###### SIDEBAR ###### | |
|
Juan C. Espinoza
|
r85 | kwargs.update(sidebar(conf=conf)) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | return render(request, '%s_conf_edit.html' % conf.device.device_type.name, kwargs) | |
|
Miguel Urco
|
r30 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r30 | def dev_conf_import(request, id_conf): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r30 | conf = get_object_or_404(Configuration, pk=id_conf) | |
|
Juan C. Espinoza
|
r172 | DevConfForm = CONF_FORMS[conf.device.device_type.name] | |
|
Miguel Urco
|
r53 | if request.method == 'GET': | |
| file_form = UploadFileForm() | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | if request.method == 'POST': | |
| file_form = UploadFileForm(request.POST, request.FILES) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | if file_form.is_valid(): | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r266 | data = conf.import_from_file(request.FILES['file']) | |
|
Juan C. Espinoza
|
r316 | parms = Params(data=data).get_conf( | |
| dtype=conf.device.device_type.name) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | if parms: | |
|
Fiorella Quino
|
r266 | ||
|
Miguel Urco
|
r53 | form = DevConfForm(initial=parms, instance=conf) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | kwargs = {} | |
| kwargs['id_dev'] = conf.id | |||
| kwargs['form'] = form | |||
| kwargs['title'] = 'Device Configuration' | |||
| kwargs['suptitle'] = 'Parameters imported' | |||
| kwargs['button'] = 'Save' | |||
| kwargs['action'] = conf.get_absolute_url_edit() | |||
| kwargs['previous'] = conf.get_absolute_url() | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | ###### SIDEBAR ###### | |
|
Juan C. Espinoza
|
r85 | kwargs.update(sidebar(conf=conf)) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | messages.success( | |
| request, "Parameters imported from: '%s'." % request.FILES['file'].name) | |||
|
Fiorella Quino
|
r266 | ||
|
Juan C. Espinoza
|
r79 | return render(request, '%s_conf_edit.html' % conf.device.device_type.name, kwargs) | |
|
Miguel Urco
|
r53 | ||
| messages.error(request, "Could not import parameters from file") | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | kwargs = {} | |
| kwargs['id_dev'] = conf.id | |||
| kwargs['title'] = 'Device Configuration' | |||
| kwargs['form'] = file_form | |||
| kwargs['suptitle'] = 'Importing file' | |||
| kwargs['button'] = 'Import' | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_configurations'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r85 | kwargs.update(sidebar(conf=conf)) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | return render(request, 'dev_conf_import.html', kwargs) | |
|
Miguel Urco
|
r30 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r30 | def dev_conf_export(request, id_conf): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r30 | conf = get_object_or_404(Configuration, pk=id_conf) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | if request.method == 'GET': | |
|
Miguel Urco
|
r57 | file_form = DownloadFileForm(conf.device.device_type.name) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | if request.method == 'POST': | |
|
Juan C. Espinoza
|
r316 | file_form = DownloadFileForm( | |
| conf.device.device_type.name, request.POST) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | if file_form.is_valid(): | |
|
Juan C. Espinoza
|
r316 | fields = conf.export_to_file( | |
| format=file_form.cleaned_data['format']) | |||
|
Fiorella Quino
|
r276 | if not fields['content']: | |
| messages.error(request, conf.message) | |||
| return redirect(conf.get_absolute_url_export()) | |||
|
Miguel Urco
|
r53 | response = HttpResponse(content_type=fields['content_type']) | |
|
Juan C. Espinoza
|
r316 | response['Content-Disposition'] = 'attachment; filename="%s"' % fields['filename'] | |
|
Miguel Urco
|
r53 | response.write(fields['content']) | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | return response | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | messages.error(request, "Could not export parameters") | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | kwargs = {} | |
| kwargs['id_dev'] = conf.id | |||
| kwargs['title'] = 'Device Configuration' | |||
| kwargs['form'] = file_form | |||
| kwargs['suptitle'] = 'Exporting file' | |||
| kwargs['button'] = 'Export' | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_configurations'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r53 | return render(request, 'dev_conf_export.html', kwargs) | |
|
Miguel Urco
|
r30 | ||
|
Juan C. Espinoza
|
r89 | ||
|
Juan C. Espinoza
|
r316 | @login_required | |
|
Miguel Urco
|
r19 | def dev_conf_delete(request, id_conf): | |
|
Juan C. Espinoza
|
r172 | ||
|
Miguel Urco
|
r20 | conf = get_object_or_404(Configuration, pk=id_conf) | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | if request.method == 'POST': | |
|
Juan C. Espinoza
|
r320 | if is_developer(request.user): | |
|
Miguel Urco
|
r18 | conf.delete() | |
|
Juan C. Espinoza
|
r91 | return redirect('url_dev_confs') | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r91 | messages.error(request, 'Not enough permission to delete this object') | |
|
Juan C. Espinoza
|
r172 | return redirect(conf.get_absolute_url()) | |
|
Juan C. Espinoza
|
r91 | kwargs = { | |
|
Juan C. Espinoza
|
r316 | 'title': 'Delete', | |
| 'suptitle': 'Configuration', | |||
| 'object': conf, | |||
| 'delete': True | |||
| } | |||
|
Juan C. Espinoza
|
r320 | kwargs['menu_configurations'] = 'active' | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r91 | return render(request, 'confirm.html', kwargs) | |
|
Juan C. Espinoza
|
r25 | ||
|
Juan C. Espinoza
|
r85 | ||
| def sidebar(**kwargs): | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r85 | side_data = {} | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r85 | conf = kwargs.get('conf', None) | |
| experiment = kwargs.get('experiment', None) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r85 | if not experiment: | |
| experiment = conf.experiment | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r85 | if experiment: | |
| side_data['experiment'] = experiment | |||
| campaign = experiment.campaign_set.all() | |||
| if campaign: | |||
| side_data['campaign'] = campaign[0] | |||
|
Juan C. Espinoza
|
r316 | experiments = campaign[0].experiments.all().order_by('name') | |
|
Juan C. Espinoza
|
r85 | else: | |
| experiments = [experiment] | |||
| configurations = experiment.configuration_set.filter(type=0) | |||
| side_data['side_experiments'] = experiments | |||
|
Juan C. Espinoza
|
r316 | side_data['side_configurations'] = configurations.order_by( | |
| 'device__device_type__name') | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r85 | return side_data | |
|
Juan C. Espinoza
|
r46 | ||
|
Juan C. Espinoza
|
r316 | ||
| def get_paginator(model, page, order, filters={}, n=8): | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | kwargs = {} | |
| query = Q() | |||
| if isinstance(filters, QueryDict): | |||
| filters = filters.dict() | |||
| [filters.pop(key) for key in filters.keys() if filters[key] in ('', ' ')] | |||
| filters.pop('page', None) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r306 | fields = [f.name for f in model._meta.get_fields()] | |
|
Juan C. Espinoza
|
r186 | if 'template' in filters: | |
| filters['template'] = True | |||
|
Juan C. Espinoza
|
r306 | if 'historical' in filters: | |
| filters.pop('historical') | |||
| filters['type'] = 1 | |||
| elif 'type' in fields: | |||
| filters['type'] = 0 | |||
|
Juan C. Espinoza
|
r138 | if 'start_date' in filters: | |
| filters['start_date__gte'] = filters.pop('start_date') | |||
| if 'end_date' in filters: | |||
| filters['start_date__lte'] = filters.pop('end_date') | |||
| if 'tags' in filters: | |||
|
Juan C. Espinoza
|
r172 | tags = filters.pop('tags') | |
|
Juan C. Espinoza
|
r186 | if 'tags' in fields: | |
|
Juan C. Espinoza
|
r172 | query = query | Q(tags__icontains=tags) | |
|
Juan C. Espinoza
|
r316 | if 'label' in fields: | |
| query = query | Q(label__icontains=tags) | |||
|
Juan C. Espinoza
|
r186 | if 'location' in fields: | |
|
Juan C. Espinoza
|
r138 | query = query | Q(location__name__icontains=tags) | |
|
Juan C. Espinoza
|
r186 | if 'device' in fields: | |
| query = query | Q(device__device_type__name__icontains=tags) | |||
|
Juan C. Espinoza
|
r316 | query = query | Q(device__location__name__icontains=tags) | |
| if 'device_type' in fields: | |||
| query = query | Q(device_type__name__icontains=tags) | |||
|
Juan C. Espinoza
|
r138 | ||
|
Juan C. Espinoza
|
r316 | if 'mine' in filters: | |
| filters['author_id'] = filters['mine'] | |||
| filters.pop('mine') | |||
|
Juan C. Espinoza
|
r138 | object_list = model.objects.filter(query, **filters).order_by(*order) | |
| paginator = Paginator(object_list, n) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | try: | |
| objects = paginator.page(page) | |||
| except PageNotAnInteger: | |||
| objects = paginator.page(1) | |||
| except EmptyPage: | |||
| objects = paginator.page(paginator.num_pages) | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | kwargs['objects'] = objects | |
| kwargs['offset'] = (int(page)-1)*n if page else 0 | |||
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r138 | return kwargs | |
|
Juan C. Espinoza
|
r46 | ||
|
Juan C. Espinoza
|
r316 | ||
|
Fiorella Quino
|
r50 | def operation(request, id_camp=None): | |
|
Juan C. Espinoza
|
r172 | ||
| kwargs = {} | |||
|
Juan C. Espinoza
|
r196 | kwargs['title'] = 'Radars Operation' | |
|
Juan C. Espinoza
|
r175 | kwargs['no_sidebar'] = True | |
|
Juan C. Espinoza
|
r320 | kwargs['menu_operation'] = 'active' | |
|
Juan C. Espinoza
|
r172 | campaigns = Campaign.objects.filter(start_date__lte=datetime.now(), | |
| end_date__gte=datetime.now()).order_by('-start_date') | |||
|
Juan C. Espinoza
|
r174 | ||
|
Juan C. Espinoza
|
r172 | if id_camp: | |
|
Juan C. Espinoza
|
r316 | campaign = get_object_or_404(Campaign, pk=id_camp) | |
| form = OperationForm( | |||
| initial={'campaign': campaign.id}, campaigns=campaigns) | |||
|
Juan C. Espinoza
|
r172 | kwargs['campaign'] = campaign | |
| else: | |||
|
Juan C. Espinoza
|
r306 | # form = OperationForm(campaigns=campaigns) | |
| kwargs['campaigns'] = campaigns | |||
|
Juan C. Espinoza
|
r172 | return render(request, 'operation.html', kwargs) | |
|
Fiorella Quino
|
r69 | #---Experiment | |
|
Fiorella Quino
|
r81 | keys = ['id', 'name', 'start_time', 'end_time', 'status'] | |
|
Fiorella Quino
|
r50 | kwargs['experiment_keys'] = keys[1:] | |
| kwargs['experiments'] = experiments | |||
| #---Radar | |||
|
Fiorella Quino
|
r211 | kwargs['locations'] = campaign.get_experiments_by_radar() | |
| kwargs['form'] = form | |||
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r69 | return render(request, 'operation.html', kwargs) | |
|
Juan C. Espinoza
|
r89 | ||
|
Fiorella Quino
|
r211 | @login_required | |
|
Juan C. Espinoza
|
r196 | def radar_start(request, id_camp, id_radar): | |
|
Fiorella Quino
|
r211 | ||
|
Juan C. Espinoza
|
r316 | campaign = get_object_or_404(Campaign, pk=id_camp) | |
|
Juan C. Espinoza
|
r196 | experiments = campaign.get_experiments_by_radar(id_radar)[0]['experiments'] | |
|
Juan C. Espinoza
|
r306 | now = datetime.now() | |
|
Juan C. Espinoza
|
r196 | for exp in experiments: | |
|
Juan C. Espinoza
|
r306 | start = datetime.combine(datetime.now().date(), exp.start_time) | |
| r311 | end = datetime.combine(datetime.now().date(), exp.end_time) | ||
|
Juan C. Espinoza
|
r306 | if end < start: | |
| end += timedelta(1) | |||
|
Juan C. Espinoza
|
r316 | ||
|
Juan C. Espinoza
|
r196 | if exp.status == 2: | |
|
Juan C. Espinoza
|
r316 | messages.warning( | |
| request, 'Experiment {} already running'.format(exp)) | |||
|
Juan C. Espinoza
|
r196 | continue | |
|
Fiorella Quino
|
r211 | ||
|
Juan C. Espinoza
|
r196 | if exp.status == 3: | |
|
Juan C. Espinoza
|
r316 | messages.warning( | |
| request, 'Experiment {} already programmed'.format(exp)) | |||
|
Juan C. Espinoza
|
r196 | continue | |
|
Fiorella Quino
|
r211 | ||
|
Juan C. Espinoza
|
r306 | if start > campaign.end_date or start < campaign.start_date: | |
|
Juan C. Espinoza
|
r196 | messages.warning(request, 'Experiment {} out of date'.format(exp)) | |
| continue | |||
|
Fiorella Quino
|
r211 | ||
|
Juan C. Espinoza
|
r306 | if now > start and now <= end: | |
| r311 | exp.status = 3 | ||
| exp.save() | |||
| task = task_start.delay(exp.id) | |||
|
Juan C. Espinoza
|
r196 | exp.status = task.wait() | |
|
Juan C. Espinoza
|
r316 | if exp.status == 0: | |
|
Juan C. Espinoza
|
r196 | messages.error(request, 'Experiment {} not start'.format(exp)) | |
|
Juan C. Espinoza
|
r316 | if exp.status == 2: | |
|
Juan C. Espinoza
|
r196 | messages.success(request, 'Experiment {} started'.format(exp)) | |
| else: | |||
|
Juan C. Espinoza
|
r316 | task = task_start.apply_async( | |
| (exp.pk, ), eta=start+timedelta(hours=5)) | |||
| r311 | exp.task = task.id | ||
|
Juan C. Espinoza
|
r196 | exp.status = 3 | |
|
Juan C. Espinoza
|
r316 | messages.success( | |
| request, 'Experiment {} programmed to start at {}'.format(exp, start)) | |||
|
Fiorella Quino
|
r211 | ||
|
Juan C. Espinoza
|
r196 | exp.save() | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r196 | return HttpResponseRedirect(reverse('url_operation', args=[id_camp])) | |
|
Fiorella Quino
|
r84 | ||
|
Fiorella Quino
|
r88 | ||
|
Fiorella Quino
|
r211 | @login_required | |
|
Fiorella Quino
|
r84 | def radar_stop(request, id_camp, id_radar): | |
|
Fiorella Quino
|
r211 | ||
|
Juan C. Espinoza
|
r316 | campaign = get_object_or_404(Campaign, pk=id_camp) | |
|
Fiorella Quino
|
r211 | experiments = campaign.get_experiments_by_radar(id_radar)[0]['experiments'] | |
| for exp in experiments: | |||
| r311 | if exp.task: | ||
| app.control.revoke(exp.task) | |||
|
Juan C. Espinoza
|
r196 | if exp.status == 2: | |
| r311 | exp.stop() | ||
|
Fiorella Quino
|
r211 | messages.warning(request, 'Experiment {} stopped'.format(exp)) | |
| r311 | exp.status = 1 | ||
| exp.save() | |||
|
Juan C. Espinoza
|
r85 | ||
|
Juan C. Espinoza
|
r196 | return HttpResponseRedirect(reverse('url_operation', args=[id_camp])) | |
|
Juan C. Espinoza
|
r172 | ||
|
Fiorella Quino
|
r88 | ||
|
Fiorella Quino
|
r211 | @login_required | |
|
Fiorella Quino
|
r88 | def radar_refresh(request, id_camp, id_radar): | |
|
Juan C. Espinoza
|
r172 | ||
|
Juan C. Espinoza
|
r316 | campaign = get_object_or_404(Campaign, pk=id_camp) | |
|
Fiorella Quino
|
r211 | experiments = campaign.get_experiments_by_radar(id_radar)[0]['experiments'] | |
| for exp in experiments: | |||
|
Juan C. Espinoza
|
r196 | exp.get_status() | |
|
Fiorella Quino
|
r88 | ||
|
Juan C. Espinoza
|
r196 | return HttpResponseRedirect(reverse('url_operation', args=[id_camp])) | |
|
Fiorella Quino
|
r282 | ||
| def real_time(request): | |||
| graphic_path = "/home/fiorella/Pictures/catwbeanie.jpg" | |||
| kwargs = {} | |||
| kwargs['title'] = 'CLAIRE' | |||
| kwargs['suptitle'] = 'Real Time' | |||
| kwargs['no_sidebar'] = True | |||
| kwargs['graphic_path'] = graphic_path | |||
| kwargs['graphic1_path'] = 'http://www.bluemaize.net/im/girls-accessories/shark-beanie-11.jpg' | |||
| r311 | return render(request, 'real_time.html', kwargs) | ||
|
Juan C. Espinoza
|
r320 | ||
| def theme(request, theme): | |||
| user = request.user | |||
| user.profile.theme = theme | |||
| user.save() | |||
| return redirect('index') |