1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
|
from django.shortcuts import render, redirect
from django.http import Http404,HttpResponse
from django.contrib.auth.decorators import login_required
from django.views.decorators.csrf import csrf_exempt
from sbhs_server.tables.models import Board, Booking, Slot, Experiment
from sbhs_server import settings,sbhs
import subprocess,json,serial,os, datetime
# Create your views here.
def checkadmin(req):
if not req.user.is_admin:
raise Http404
@login_required(redirect_field_name=None)
def index(req):
checkadmin(req)
boards = Board.objects.order_by('online').all()
allotment_mode = "Random" if Board.can_do_random_allotment() else "Workshop"
return render(req, 'admin/index.html', {"boards": boards, "allotment_mode": allotment_mode})
@login_required(redirect_field_name=None)
def toggle_allotment_mode(req):
checkadmin(req)
Board.toggle_random_allotment()
return redirect(index)
@login_required(redirect_field_name=None)
def booking_index(req):
checkadmin(req)
bookings = Booking.objects.order_by('-booking_date','-slot_id').filter(trashed_at__isnull=True).select_related()[:50]
return render(req, 'admin/booking_index.html', {"bookings": bookings})
@login_required(redirect_field_name=None)
def webcam_index(req):
checkadmin(req)
boards = Board.objects.all()
return render(req, 'admin/webcam_index.html', {"boards": boards})
@login_required(redirect_field_name=None)
def profile(req, mid):
checkadmin(req)
try:
filename = settings.SBHS_GLOBAL_LOG_DIR + "/" + mid + ".log"
f = open(filename, "r")
f.close()
except:
raise Http404
delta_T = 1000
data = subprocess.check_output("tail -n %d %s" % (delta_T, filename), shell=True)
data = data.split("\n")
plot = []
heatcsv = ""
fancsv = ""
tempcsv = ""
for t in xrange(len(data)):
line = data[t]
entry = line.strip().split(" ")
try:
plot.append([int(i) for i in entry[0:-1] + [float(entry[-1])]])
heatcsv += "%d,%s\\n" % (t+1, entry[1])
fancsv += "%d,%s\\n" % (t+1, entry[2])
tempcsv += "%d,%s\\n" % (t+1, entry[3])
except:
continue
plot = zip(*plot) # transpose
return render(req, "admin/profile.html", {
"mid": mid,
"delta_T": delta_T,
"heat": heatcsv,
"fan": fancsv,
"temp": tempcsv
})
@login_required(redirect_field_name=None)
def testing(req):
checkadmin(req)
now = datetime.datetime.now()
current_slot_id = Slot.objects.filter(start_hour=now.hour,
start_minute__lt=now.minute,
end_minute__gt=now.minute)
current_slot_id = -1 if not current_slot_id else current_slot_id[0].id
current_bookings = Booking.objects.filter(slot_id=current_slot_id,
booking_date=datetime.date.today()).select_related()
current_mids = list([-1]) if not current_bookings else [current_booking.account.board.mid for current_booking in current_bookings]
boards = Board.objects.filter(online=1)
allotment_mode = "Random" if Board.can_do_random_allotment() else "Workshop"
return render(req, 'admin/testexp.html', {"boards": boards, "allotment_mode": allotment_mode, "mids": current_mids})
@csrf_exempt
def monitor_experiment(req):
checkadmin(req)
try:
mid = int(req.POST.get("mid"))
except Exception as e:
return HttpResponse(json.dumps({"status_code":400, "message":"Invalid parameters"}), content_type="application/json")
now = datetime.datetime.now()
current_slot_id = Slot.objects.filter(start_hour=now.hour,
start_minute__lt=now.minute,
end_minute__gt=now.minute)
current_slot_id = -1 if not current_slot_id else current_slot_id[0].id
try:
current_booking = Booking.objects.get(slot_id=current_slot_id,
booking_date=datetime.date.today(),
account__board__mid=mid)
except Exception as e:
return HttpResponse(json.dumps({"status_code":400, "message":"Invalid MID"}), content_type="application/json")
current_booking_id, current_user = current_booking.id, current_booking.account.username
logfile = Experiment.objects.get(booking_id=current_booking_id).log
# get last 50 lines from logs
stdin,stdout = os.popen2("tail -n 10 "+logfile)
stdin.close()
logs = stdout.readlines(); stdout.close()
logs = "".join(logs)
data = {"user": current_user, "logs": logs}
return HttpResponse(json.dumps({"status_code":200, "message":data}), content_type="application/json")
@login_required(redirect_field_name=None)
def download_log(req, mid):
checkadmin(req)
try:
global_logfile = settings.SBHS_GLOBAL_LOG_DIR + "/" + mid + ".log"
f = open(global_logfile, "r")
data = f.read()
f.close()
return HttpResponse(data, content_type='text/text')
except:
return HttpResponse("Requested log file doesn't exist.")
@csrf_exempt
def reset_device(req):
"""Resets the device to fan = 100 and heat = 0
Takes mid as paramter
Returns status_code = 200, data={temp:temp of the device} if succesful
else
status_code = 500 , data={error:errorMessage}
"""
mid=int(req.POST.get('mid'))
usb_path=settings.MID_PORT_MAP.get(mid,None)
if usb_path is None:
retVal={"status_code":400,"message":"Invalid MID"}
return HttpResponse(json.dumps(retVal),content_type='application/json')
#trying to connect to device
# check if SBHS device is connected
if not os.path.exists(usb_path):
retVal={"status_code":500,"message":"Device Not connected to defined USB Port"}
return HttpResponse(json.dumps(retVal),content_type='application/json')
try:
board = sbhs.Sbhs()
board.machine_id=mid
board.boardcon= serial.Serial(port=usb_path, baudrate=9600, bytesize=8, parity='N', stopbits=1, timeout=2) #orignal stopbits = 1
board.status = 1
if board.reset_board():
retVal={"status_code":200,"message":board.getTemp()}
return HttpResponse(json.dumps(retVal),content_type='application/json')
else:
retVal={"status_code":500,"message":"Could not set the parameters.Try again."}
return HttpResponse(json.dumps(retVal),content_type='application/json')
except serial.serialutil.SerialException:
retVal={"status_code":500,"message":"Could not connect to the device.Try again."}
return HttpResponse(json.dumps(retVal),content_type='application/json')
@csrf_exempt
def set_device_params(req):
"""Sets the device parameters as per the arguments sent
Takes mid,fan,heat as paramter
Returns status_code = 200, data={temp:temp of the device} if succesful
else
status_code = 500 , data={error:errorMessage}
"""
mid=int(req.POST.get('mid'))
fan=int(req.POST.get('fan'))
heat=int(req.POST.get('heat'))
usb_path=settings.MID_PORT_MAP.get(mid,None)
if usb_path is None:
retVal={"status_code":400,"message":"Invalid MID"}
return HttpResponse(json.dumps(retVal),content_type='application/json')
#trying to connect to device
# check if SBHS device is connected
if not os.path.exists(usb_path):
retVal={"status_code":500,"message":"Device Not connected to defined USB Port"}
return HttpResponse(json.dumps(retVal),content_type='application/json')
try:
board = sbhs.Sbhs()
board.machine_id=mid
board.boardcon= serial.Serial(port=usb_path, baudrate=9600, bytesize=8, parity='N', stopbits=1, timeout=2) #orignal stopbits = 1
board.status = 1
if board.setFan(fan) and board.setHeat(heat):
retVal={"status_code":200,"message":board.getTemp()}
return HttpResponse(json.dumps(retVal),content_type='application/json')
else:
retVal={"status_code":500,"message":"Could not set the parameters.Try again."}
return HttpResponse(json.dumps(retVal),content_type='application/json')
except serial.serialutil.SerialException:
retVal={"status_code":500,"message":"Could not connect to the device.Try again."}
return HttpResponse(json.dumps(retVal),content_type='application/json')
@csrf_exempt
def get_device_temp(req):
"""Sets the device parameters as per the arguments sent
Takes mid,fan,heat as paramter
Returns status_code = 200, data={temp:temp of the device} if succesful
else
status_code = 500 , data={error:errorMessage}
"""
mid=int(req.POST.get('mid'))
usb_path=settings.MID_PORT_MAP.get(mid,None)
if usb_path is None:
retVal={"status_code":400,"message":"Invalid MID"}
return HttpResponse(json.dumps(retVal),content_type='application/json')
#trying to connect to device
# check if SBHS device is connected
if not os.path.exists(usb_path):
retVal={"status_code":500,"message":"Device Not connected to defined USB Port"}
return HttpResponse(json.dumps(retVal),content_type='application/json')
try:
board = sbhs.Sbhs()
board.machine_id=mid
board.boardcon= serial.Serial(port=usb_path, baudrate=9600, bytesize=8, parity='N', stopbits=1, timeout=2) #orignal stopbits = 1
board.status = 1
temp=board.getTemp()
if temp!=0.0:
retVal={"status_code":200,"message":temp}
return HttpResponse(json.dumps(retVal),content_type='application/json')
else:
retVal={"status_code":500,"message":"Could not set the parameters.Try again."}
return HttpResponse(json.dumps(retVal),content_type='application/json')
except serial.serialutil.SerialException:
retVal={"status_code":500,"message":"Could not connect to the device.Try again."}
return HttpResponse(json.dumps(retVal),content_type='application/json')
|
