radarsys Commit - r388:7b60d9ecd28a · Jicamarca Repository

Avance scheduler

Renato Huallpa -

r388:7b60d9ecd28a

parent child

Context file:

r388:7b60d9ecd28a

Collapse all files

apps/abs/models.py +1 -1

                 def stop_device(self):
+                    print("estoy en ABS models")
                     self.device.status = 2
                     self.device.save()
                     self.message = 'ABS has been stopped.'

apps/abs/mqtt.py +1 -1

             def on_connect(mqtt_client, userdata, flags, rc):
                if rc == 0:
-                   print('Connected successfully')
+                #    print('Connected successfully')
                    mqtt_client.subscribe(os.environ.get('TOPIC_ABS_ACK','abs/beams_ack'))
                else:
                    print('Bad connection. Code:', rc)

apps/atrad/mqtt.py +1 -1

             def on_connect(mqtt_client, userdata, flags, rc):
                if rc == 0:
-                   print('Connected successfully')
+                #    print('Connected successfully')
                    mqtt_client.subscribe('atrad/test3')
                else:
                    print('Bad connection. Code:', rc)

apps/main/management/commands/hello.py +90 -6

@@ -1,5 +1,14
1	from django.core.management.base import BaseCommand	1	from django.core.management.base import BaseCommand
2		2	from apps.main.models import Campaign, Location
		3	from datetime import datetime,timedelta
		4	from apps.main.views import radar_start
		5	from django.shortcuts import render, redirect,get_object_or_404, HttpResponse
		6	from django.urls import reverse
		7	from django.utils.timezone import is_aware
		8	from django.contrib import messages
		9	from django.http import HttpResponseRedirect
		10	from apps.main.views import experiment_start
		11	from apps.main.models import Experiment, Configuration
3		12
4	class Command(BaseCommand):	13	class Command(BaseCommand):
5	"""	14	"""
@@ -8,12 +17,87 class Command(BaseCommand):
8	manage.py restart_experiment	17	manage.py restart_experiment
9	"""	18	"""
10	def handle(self, args, *options):	19	def handle(self, args, *options):
11	print("~~Hola~~")	20	print("")
		21	campaigns = Campaign.objects.filter(start_date__lte=datetime.now(),
		22	end_date__gte=datetime.now()).order_by('-start_date')
		23
		24	if campaigns:
		25
		26	for campaign in campaigns:
		27	print(campaign.name)
		28	print(campaign.start_date)
		29	print(campaign.end_date)
		30	print(campaign.experiments.all()[0].id)
		31	print("STATUS: ",campaign.experiments.all()[0].status)
		32
		33	radar=campaign.get_experiments_by_radar(radar=None)
		34	radar_id=radar[0]["id"]
		35	print(radar_id)
		36
		37	now = datetime.now()
		38	if now<campaign.end_date and now >campaign.start_date:
		39	print("La campaña",campaign.name ,"se ejecuta!",flush=True)
		40	radar_start_scheduler(campaign.id,radar_id)
		41
		42	else:
		43	copy_campaigns=Campaign.objects.all()
		44	print("-------------Deteniendo procesos-------------")
		45	for campaign in copy_campaigns:
		46	print(campaign.name)
		47	print(campaign.start_date)
		48	print(campaign.end_date)
		49	print("ID: ",campaign.experiments.all()[0].id)
		50	print("STATUS: ",campaign.experiments.all()[0].status)
		51	print("----,,,---")
		52	radar=campaign.get_experiments_by_radar(radar=None)
		53	radar_id=radar[0]["id"]
		54
		55	if campaign.experiments.all()[0].status !=1:
		56	print("Estoy en :",campaign.experiments.all()[0].status)
		57	print("Con ID: ",campaign.experiments.all()[0].id)
		58	print("\n\n")
		59	a=radar_stop_scheduler(campaign.id,radar_id,campaign.experiments.all()[0].id)
		60	print("RETURN", a)
		61
		62
		63	def radar_start_scheduler(id_camp,id_radar):
		64	print("-------------------")
		65	campaign = get_object_or_404(Campaign, pk=id_camp)
		66	experiments = campaign.get_experiments_by_radar(id_radar)[0]['experiments']
		67	now = datetime.now()
		68
		69	for exp in experiments:
		70	exp = get_object_or_404(Experiment, pk=exp.id)
12		71
13	# def main():	72	if exp.status == 2:
14	# print("Hola")	73	print('Experiment {} already runnnig'.format(exp))
		74	else:
		75	exp.status = exp.start()
		76	if exp.status == 0:
		77	print('Experiment {} not start'.format(exp))
		78	if exp.status == 2:
		79	print('Experiment {} started'.format(exp))
		80	exp.save()
15		81
16	# if __name__=='__main__':	82	def radar_stop_scheduler(id_camp,id_radar,id_experiment):
17	# main()	83	print("-------------------")
		84	'''
		85	Stop experiments's devices
		86	DDS-JARS-RC-CGS-ABS
		87	'''
		88	exp=get_object_or_404(Experiment,pk=id_experiment)
18		89
		90	if exp.status == 2:
		91	confs = Configuration.objects.filter(experiment=id_experiment,type = 0).order_by('device__device_type__sequence')
		92	confs = confs.exclude(device__device_type__name='cgs')
		93	try:
		94	for conf in confs:
		95	print("Estoy en conf_scheduler")
		96	print(conf)
		97	conf.stop_device()
		98	exp.status= 1
		99	except:
		100	exp.status= 0
		101	exp.save()
19		102
		103	return exp.status No newline at end of file

apps/main/models.py 0 -1

                         dum['id']          = loc.pk
                         dum['experiments'] = [e for e in self.experiments.all() if e.location==loc]
                         ret.append(dum)
                     return ret
                 def get_absolute_url(self):

apps/main/mqtt.py +1 -1

             def on_connect(mqtt_client, userdata, flags, rc):
                if rc == 0:
-                   print('Connected successfully')
+                   #print('Connected successfully')
                    mqtt_client.subscribe(os.environ.get('TOPIC_ABS_ACK','abs/beams_ack'))
                else:
                    print('Bad connection. Code:', rc)

apps/main/views.py +12 -12

             @login_required
             def radar_start(request, id_camp, id_radar):
+                print("Boton presionados",flush=True)
                 campaign    = get_object_or_404(Campaign, pk=id_camp)
                 experiments = campaign.get_experiments_by_radar(id_radar)[0]['experiments']
                 now         = datetime.now()
                 for exp in experiments:
                     #app.control.revoke(exp.task)
                     print("----------------------")
-                    print("status:->", exp.status)
+                    print("status:->", exp.status,flush=True)
                     start = datetime.combine(datetime.now().date(), exp.start_time)
                     end   = datetime.combine(datetime.now().date(), exp.end_time)
-                    print("start exp: ",exp.start_time)
+                    print("start exp: ",exp.start_time,flush=True)
-                    print("end exp: ",exp.end_time)
+                    print("end exp: ",exp.end_time,flush=True)
-                    print("start comb: ",start)
+                    print("start comb: ",start,flush=True)
-                    print("end comb: ",end)
+                    print("end comb: ",end,flush=True)
-                    print(is_aware(start))
+                    print(is_aware(start),flush=True)
-                    print("start camp",campaign.start_date)
+                    print("start camp",campaign.start_date,flush=True)
-                    print("end camp",campaign.end_date)
+                    print("end camp",campaign.end_date,flush=True)
-                    print(is_aware(campaign.start_date))
+                    print(is_aware(campaign.start_date),flush=True)
                     if end < start:
                         end += timedelta(1)
                             request, 'Experiment {} out of date'.format(exp))
                     #app.control.revoke(exp.task)
-                    print("Llego luego del revoke")
+                    print("Llego luego del revoke",flush=True)
                     if now >= start and now <= end:
-                        print("Caso now > start and < end -- (1)")
+                        print("Caso now > start and < end -- (1)",flush=True)
                         # -------------------------------------------

General Comments 0

Write
Preview

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

No TODOs yet

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

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