|
|
from django.shortcuts import render
|
|
|
from django.template import RequestContext
|
|
|
from django.shortcuts import redirect, render, get_object_or_404
|
|
|
from django.contrib import messages
|
|
|
from django.conf import settings
|
|
|
from django.http import HttpResponse
|
|
|
from django.urls import reverse
|
|
|
from django.views.decorators.csrf import csrf_exempt
|
|
|
from django.utils.safestring import mark_safe
|
|
|
|
|
|
from datetime import datetime
|
|
|
from time import sleep
|
|
|
import os
|
|
|
import io
|
|
|
|
|
|
from apps.main.models import Device, Configuration, Experiment
|
|
|
from apps.main.views import sidebar
|
|
|
|
|
|
from .models import ABSConfiguration, ABSBeam
|
|
|
from .forms import ABSConfigurationForm, ABSBeamEditForm, ABSBeamAddForm, ABSImportForm
|
|
|
|
|
|
from .utils.overJroShow import overJroShow
|
|
|
#from .utils.OverJRO import OverJRO
|
|
|
#Create your views here.
|
|
|
import json, ast
|
|
|
|
|
|
from .mqtt import client as mqtt_client
|
|
|
from radarsys.socketconfig import sio as sio
|
|
|
|
|
|
def get_values_from_form(form_data):
|
|
|
|
|
|
sublistup = []
|
|
|
sublistdown = []
|
|
|
subtxlistup = []
|
|
|
subtxlistdown = []
|
|
|
subrxlistup = []
|
|
|
subrxlistdown = []
|
|
|
|
|
|
up_values_list = []
|
|
|
down_values_list = []
|
|
|
up_txvalues_list = []
|
|
|
down_txvalues_list = []
|
|
|
up_rxvalues_list = []
|
|
|
down_rxvalues_list = []
|
|
|
|
|
|
values_list = {}
|
|
|
cont = 1
|
|
|
|
|
|
for i in range(1,65):
|
|
|
x = float(form_data['abs_up'+str(i)])
|
|
|
y = float(form_data['abs_down'+str(i)])
|
|
|
sublistup.append(x)
|
|
|
sublistdown.append(y)
|
|
|
|
|
|
if str(i) in form_data.getlist('uptx_checks'):
|
|
|
subtxlistup.append(1)
|
|
|
else:
|
|
|
subtxlistup.append(0)
|
|
|
if str(i) in form_data.getlist('downtx_checks'):
|
|
|
subtxlistdown.append(1)
|
|
|
else:
|
|
|
subtxlistdown.append(0)
|
|
|
|
|
|
if str(i) in form_data.getlist('uprx_checks'):
|
|
|
subrxlistup.append(1)
|
|
|
else:
|
|
|
subrxlistup.append(0)
|
|
|
if str(i) in form_data.getlist('downrx_checks'):
|
|
|
subrxlistdown.append(1)
|
|
|
else:
|
|
|
subrxlistdown.append(0)
|
|
|
|
|
|
cont = cont+1
|
|
|
|
|
|
if cont == 9:
|
|
|
up_values_list.append(sublistup)
|
|
|
down_values_list.append(sublistdown)
|
|
|
sublistup = []
|
|
|
sublistdown = []
|
|
|
|
|
|
up_txvalues_list.append(subtxlistup)
|
|
|
down_txvalues_list.append(subtxlistdown)
|
|
|
subtxlistup = []
|
|
|
subtxlistdown = []
|
|
|
up_rxvalues_list.append(subrxlistup)
|
|
|
down_rxvalues_list.append(subrxlistdown)
|
|
|
subrxlistup = []
|
|
|
subrxlistdown = []
|
|
|
cont = 1
|
|
|
|
|
|
|
|
|
list_uesup = []
|
|
|
list_uesdown = []
|
|
|
for i in range(1,5):
|
|
|
if form_data['ues_up'+str(i)] == '':
|
|
|
list_uesup.append(0.0)
|
|
|
else:
|
|
|
list_uesup.append(float(form_data['ues_up'+str(i)]))
|
|
|
|
|
|
if form_data['ues_down'+str(i)] == '':
|
|
|
list_uesdown.append(0.0)
|
|
|
else:
|
|
|
list_uesdown.append(float(form_data['ues_down'+str(i)]))
|
|
|
|
|
|
onlyrx_list = form_data.getlist('onlyrx')
|
|
|
only_rx = {}
|
|
|
if '1' in onlyrx_list:
|
|
|
only_rx['up'] = True
|
|
|
else:
|
|
|
only_rx['up'] = False
|
|
|
if '2' in onlyrx_list:
|
|
|
only_rx['down'] = True
|
|
|
else:
|
|
|
only_rx['down'] = False
|
|
|
|
|
|
antenna = {'antenna_up': up_values_list, 'antenna_down': down_values_list}
|
|
|
tx = {'up': up_txvalues_list, 'down': down_txvalues_list}
|
|
|
rx = {'up': up_rxvalues_list, 'down': down_rxvalues_list}
|
|
|
ues = {'up': list_uesup, 'down': list_uesdown}
|
|
|
name = str(form_data['beam_name'])
|
|
|
|
|
|
beam_data = {'name': name, 'antenna': antenna, 'tx': tx, 'rx': rx, 'ues': ues, 'only_rx': only_rx}
|
|
|
|
|
|
return beam_data
|
|
|
|
|
|
|
|
|
def abs_conf(request, id_conf):
|
|
|
|
|
|
conf = get_object_or_404(ABSConfiguration, pk=id_conf)
|
|
|
beams = ABSBeam.objects.filter(abs_conf=conf)
|
|
|
#------------Colors for Active Beam:-------------
|
|
|
all_status = {}
|
|
|
module_messages = json.loads(conf.module_messages)
|
|
|
|
|
|
color_status = {}
|
|
|
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'
|
|
|
elif status == '2':
|
|
|
all_status['{}'.format(i+1)] = 1
|
|
|
color_status['{}'.format(i+1)] = 'class=text-info'
|
|
|
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'
|
|
|
#------------------------------------------------
|
|
|
|
|
|
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)
|
|
|
|
|
|
kwargs['beams'] = beams
|
|
|
kwargs['modules_status'] = all_status
|
|
|
kwargs['color_status'] = color_status
|
|
|
kwargs['module_messages'] = module_messages
|
|
|
###### SIDEBAR ######
|
|
|
kwargs.update(sidebar(conf=conf))
|
|
|
|
|
|
return render(request, 'abs_conf.html', kwargs)
|
|
|
|
|
|
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)
|
|
|
|
|
|
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);
|
|
|
# def abs_conf_mqtt(request, id_conf):
|
|
|
# # socket.on('beams_ack',function(data){
|
|
|
# ack=data;
|
|
|
# console.log("ack")
|
|
|
# console.log(ack)
|
|
|
# })
|
|
|
|
|
|
|
|
|
def abs_conf_edit(request, id_conf):
|
|
|
|
|
|
conf = get_object_or_404(ABSConfiguration, pk=id_conf)
|
|
|
|
|
|
beams = ABSBeam.objects.filter(abs_conf=conf)
|
|
|
|
|
|
if request.method=='GET':
|
|
|
form = ABSConfigurationForm(instance=conf)
|
|
|
|
|
|
if request.method=='POST':
|
|
|
form = ABSConfigurationForm(request.POST, instance=conf)
|
|
|
|
|
|
if form.is_valid():
|
|
|
conf = form.save(commit=False)
|
|
|
conf.save()
|
|
|
return redirect('url_abs_conf_mqtt', id_conf=conf.id)
|
|
|
|
|
|
###### SIDEBAR ######
|
|
|
kwargs = {}
|
|
|
|
|
|
kwargs['dev_conf'] = conf
|
|
|
#kwargs['id_dev'] = conf.id
|
|
|
kwargs['id_conf'] = conf.id
|
|
|
kwargs['form'] = form
|
|
|
kwargs['abs_beams'] = beams
|
|
|
kwargs['title'] = 'Device Configuration'
|
|
|
kwargs['suptitle'] = 'Edit'
|
|
|
kwargs['button'] = 'Save'
|
|
|
kwargs['mqtt']=True
|
|
|
|
|
|
kwargs['edit'] = True
|
|
|
|
|
|
return render(request, 'abs_conf_edit.html', kwargs)
|
|
|
|
|
|
@csrf_exempt
|
|
|
def abs_conf_alert(request):
|
|
|
|
|
|
if request.method == 'POST':
|
|
|
print (request.POST)
|
|
|
return HttpResponse(json.dumps({'result':1}), content_type='application/json')
|
|
|
else:
|
|
|
return redirect('index')
|
|
|
|
|
|
|
|
|
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)
|
|
|
|
|
|
|
|
|
def send_beam(request, id_conf, id_beam):
|
|
|
|
|
|
conf = get_object_or_404(ABSConfiguration, pk=id_conf)
|
|
|
|
|
|
abs = Configuration.objects.filter(pk=conf.device.conf_active).first()
|
|
|
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())
|
|
|
|
|
|
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
|
|
|
|
|
|
i = 0
|
|
|
for b in beams_list:
|
|
|
if b.id == int(id_beam):
|
|
|
break
|
|
|
else:
|
|
|
i += 1
|
|
|
beam_pos = i + 1 #Estandarizar
|
|
|
print('{} Position {}'.format(beam.name,str(beam_pos)))
|
|
|
conf.send_beam(beam_pos)
|
|
|
|
|
|
return redirect('url_abs_conf', conf.id)
|
|
|
|
|
|
kwargs = {
|
|
|
'title': 'ABS',
|
|
|
'suptitle': conf.label,
|
|
|
'message': 'Are you sure you want to change ABS Beam through SEND BEAM to: {}?'.format(beam.name),
|
|
|
'delete': False
|
|
|
}
|
|
|
kwargs['menu_configurations'] = 'active'
|
|
|
|
|
|
return render(request, 'confirm.html', kwargs)
|
|
|
|
|
|
def change_beam_mqtt(request, id_conf, id_beam):
|
|
|
|
|
|
conf = get_object_or_404(ABSConfiguration, pk=id_conf)
|
|
|
print("conf: {}".format(conf),flush=True)
|
|
|
|
|
|
abs = Configuration.objects.filter(pk=conf.device.conf_active).first()
|
|
|
print("abs: {}".format(abs),flush=True)
|
|
|
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_mqtt_url())
|
|
|
|
|
|
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
|
|
|
|
|
|
i = 0
|
|
|
for b in beams_list:
|
|
|
if b.id == int(id_beam):
|
|
|
break
|
|
|
else:
|
|
|
i += 1
|
|
|
beam_pos = i + 1 #Estandarizar
|
|
|
|
|
|
print('{} Position {}'.format(beam.name,str(beam_pos)),flush=True)
|
|
|
conf.change_beam_mqtt(beam_pos)
|
|
|
|
|
|
# return redirect('url_abs_conf', conf.id)
|
|
|
return redirect('url_abs_conf_mqtt', conf.id)
|
|
|
# return render(request, 'abs_conf_mqtt.html',kwargs)
|
|
|
|
|
|
kwargs = {
|
|
|
'title': 'ABS',
|
|
|
'mqtt':True,
|
|
|
'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)
|
|
|
|
|
|
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(
|
|
|
name = beam_data['name'],
|
|
|
antenna = json.dumps(beam_data['antenna']),
|
|
|
abs_conf = conf,
|
|
|
tx = json.dumps(beam_data['tx']),
|
|
|
rx = json.dumps(beam_data['rx']),
|
|
|
ues = json.dumps(beam_data['ues']),
|
|
|
only_rx = json.dumps(beam_data['only_rx'])
|
|
|
)
|
|
|
new_beam.save()
|
|
|
messages.success(request, 'Beam: "%s" has been added.' % new_beam.name)
|
|
|
|
|
|
return redirect('url_edit_abs_conf', conf.id)
|
|
|
|
|
|
###### SIDEBAR ######
|
|
|
kwargs = {}
|
|
|
|
|
|
#kwargs['dev_conf'] = conf.device
|
|
|
#kwargs['id_dev'] = conf.device
|
|
|
#kwargs['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'
|
|
|
kwargs['no_sidebar'] = True
|
|
|
kwargs['edit'] = True
|
|
|
|
|
|
return render(request, 'abs_add_beam.html', kwargs)
|
|
|
|
|
|
|
|
|
def edit_beam(request, id_conf, id_beam):
|
|
|
|
|
|
conf = get_object_or_404(ABSConfiguration, pk=id_conf)
|
|
|
beam = get_object_or_404(ABSBeam, pk=id_beam)
|
|
|
|
|
|
if request.method=='GET':
|
|
|
form = ABSBeamEditForm(initial={'beam': beam})
|
|
|
|
|
|
if request.method=='POST':
|
|
|
form = ABSBeamEditForm(request.POST)
|
|
|
|
|
|
beam_data = get_values_from_form(request.POST)
|
|
|
|
|
|
beam.dict_to_parms(beam_data)
|
|
|
beam.save()
|
|
|
|
|
|
messages.success(request, 'Beam: "%s" has been updated.' % beam.name)
|
|
|
|
|
|
return redirect('url_edit_abs_conf', conf.id)
|
|
|
|
|
|
###### SIDEBAR ######
|
|
|
kwargs = {}
|
|
|
|
|
|
kwargs['id_conf'] = conf.id
|
|
|
kwargs['form'] = form
|
|
|
kwargs['title'] = 'ABS Beams'
|
|
|
kwargs['suptitle'] = 'Edit Beam'
|
|
|
kwargs['button'] = 'Save'
|
|
|
kwargs['no_sidebar'] = True
|
|
|
|
|
|
#kwargs['previous'] = conf.get_absolute_url_edit()
|
|
|
kwargs['edit'] = True
|
|
|
|
|
|
return render(request, 'abs_edit_beam.html', kwargs)
|
|
|
|
|
|
|
|
|
|
|
|
def remove_beam(request, id_conf, id_beam):
|
|
|
|
|
|
conf = get_object_or_404(ABSConfiguration, pk=id_conf)
|
|
|
beam = get_object_or_404(ABSBeam, pk=id_beam)
|
|
|
|
|
|
if request.method=='POST':
|
|
|
if beam:
|
|
|
try:
|
|
|
beam.delete()
|
|
|
messages.success(request, 'Beam: "%s" has been deleted.' % beam)
|
|
|
except:
|
|
|
messages.error(request, 'Unable to delete beam: "%s".' % beam)
|
|
|
|
|
|
return redirect('url_edit_abs_conf', conf.id)
|
|
|
|
|
|
###### SIDEBAR ######
|
|
|
kwargs = {}
|
|
|
|
|
|
kwargs['object'] = beam
|
|
|
kwargs['delete'] = True
|
|
|
kwargs['title'] = 'Delete'
|
|
|
kwargs['suptitle'] = 'Beam'
|
|
|
kwargs['previous'] = conf.get_absolute_url_edit()
|
|
|
return render(request, 'confirm.html', kwargs)
|
|
|
|
|
|
|
|
|
|
|
|
def plot_patterns(request, id_conf, id_beam=None):
|
|
|
|
|
|
kwargs = {}
|
|
|
conf = get_object_or_404(ABSConfiguration, pk=id_conf)
|
|
|
beams = ABSBeam.objects.filter(abs_conf=conf)
|
|
|
|
|
|
if id_beam:
|
|
|
beam = get_object_or_404(ABSBeam, pk=id_beam)
|
|
|
kwargs['beam'] = beam
|
|
|
|
|
|
###### SIDEBAR ######
|
|
|
|
|
|
kwargs['dev_conf'] = conf.device
|
|
|
kwargs['id_dev'] = conf.device
|
|
|
kwargs['id_conf'] = conf.id
|
|
|
kwargs['abs_beams'] = beams
|
|
|
kwargs['title'] = 'ABS Patterns'
|
|
|
kwargs['suptitle'] = conf.name
|
|
|
kwargs['no_sidebar'] = True
|
|
|
|
|
|
return render(request, 'abs_patterns.html', kwargs)
|
|
|
|
|
|
|
|
|
def plot_pattern(request, id_conf, id_beam, antenna):
|
|
|
|
|
|
if antenna=='down':
|
|
|
sleep(3)
|
|
|
|
|
|
conf = get_object_or_404(ABSConfiguration, pk=id_conf)
|
|
|
beam = get_object_or_404(ABSBeam, pk=id_beam)
|
|
|
just_rx = 1 if json.loads(beam.only_rx)[antenna] else 0
|
|
|
phases = json.loads(beam.antenna)['antenna_{}'.format(antenna)]
|
|
|
gain_tx = json.loads(beam.tx)[antenna]
|
|
|
gain_rx = json.loads(beam.rx)[antenna]
|
|
|
ues = json.loads(beam.ues)[antenna]
|
|
|
newOverJro = overJroShow(beam.name)
|
|
|
fig = newOverJro.plotPattern2(datetime.today(), phases, gain_tx, gain_rx, ues, just_rx)
|
|
|
buf = io.BytesIO()
|
|
|
fig.savefig(buf, format='png')
|
|
|
response = HttpResponse(buf.getvalue(), content_type='image/png')
|
|
|
return response
|
|
|
|
|
|
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'])
|
|
|
|
|
|
# @sio.event
|
|
|
# def change_beam(sid,message):
|
|
|
# data=str(message['data'])
|
|
|
# data=data[16]
|
|
|
# mqtt_client.publish('abs/change_beam',data)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
