##// END OF EJS Templates
ABS » abscontrol
RSS
imanay -
r158:159
parent child
Show More
Show file before | Show file after | Hide comments
@@ -18,12 +18,17
18 18 # self.rx_buffer = "default"
19 19 self.rx_buffer = rx_buffer
20 20 self.enaModules = []
21 self.bits = []
22 self.phase = []
23 self.txFile = []
24 self.rxFile = []
21 25
22 26 self.createObjects()
23 27
24 28 print "Checking control modules, please wait ..."
25 29 self.enaModules = self.checkAntenna()
26 30 print "Starting automatic control module status."
31 self.__StartingAutomaticControlModules()
27 32 self.__AutomaticControlModules()
28 33
29 34 def createObjects(self):
@@ -87,12 +92,23
87 92 # f.close()
88 93
89 94
90 def __writeFile(self, filename, data):
95 def __CreateFile(self, filename):
96
97 fobj = open(filename,"w")
98 fobj.close()
99
100 def __writeNewFile(self, filename, data):
91 101
92 102 fobj = open(filename,"w")
93 103 fobj.writelines(data)
94 104 fobj.close()
95
105
106 def __writeFile(self, filename, data):
107
108 fobj = open(filename,"a")
109 fobj.writelines(data)
110 fobj.close()
111
96 112 def checkAntenna(self):
97 113
98 114 """
@@ -197,7 +213,28
197 213
198 214 def __getControlModuleStatus(self, cmd, rx_buffer):
199 215
200 all_blocks = ""
216 # all_blocks = ""
217 # all_blocks = []
218 # enaModules = self.checkAntenna()
219 # enaModules = [11,12,13,14]
220
221 for id in range(1,65):
222 if id not in self.enaModules:
223 continue
224
225 bits = self.__ConnectionWithControlModules(rx_buffer,cmd,id)
226 del self.bits[id-1]
227 self.bits.insert(id-1, bits)
228
229 # all_blocks.append(one_block)
230 #Using tx buffer
231
232 # return all_blocks
233
234 def __getControlModuleBigPhase(self, cmd, rx_buffer):
235
236 # all_blocks = ""
237 all_blocks = []
201 238 # enaModules = self.checkAntenna()
202 239 # enaModules = [11,12,13,14]
203 240
@@ -207,42 +244,29
207 244
208 245 one_block = self.__ConnectionWithControlModules(rx_buffer,cmd,id)
209 246
210 all_blocks = all_blocks + one_block
211 #Using tx buffer
212
247 # all_blocks = all_blocks + one_block
248 all_blocks.append(one_block)
249 #Using tx buffer
213 250 return all_blocks
214
215 def __getControlModuleBigPhase(self, cmd, rx_buffer):
216
217 all_blocks = ""
218 # enaModules = self.checkAntenna()
219 # enaModules = [11,12,13,14]
220
221 for id in range(1,65):
222 if id not in self.enaModules:
223 continue
224
225 one_block = self.__ConnectionWithControlModules(rx_buffer,cmd,id)
226
227 all_blocks = all_blocks + one_block
228 #Using tx buffer
229 return all_blocks
230 251
231 252 def __getControlModuleLowPhase(self, cmd, rx_buffer):
232 253
233 all_blocks = ""
234 # enaModules = self.checkAntenna()
235 # enaModules = [11,12,13,14]
236
237 for id in range(1,65):
238 if id not in self.enaModules:
239 continue
240
241 one_block = self.__ConnectionWithControlModules(rx_buffer,cmd,id)
242
243 all_blocks = all_blocks + one_block
244 #Using tx buffer
245 return all_blocks
254 # all_blocks = ""
255 # all_blocks = []
256 # enaModules = self.checkAntenna()
257 # enaModules = [11,12,13,14]
258
259 for id in range(1,65):
260 if id not in self.enaModules:
261 continue
262
263 phase = self.__ConnectionWithControlModules(rx_buffer,cmd,id)
264 del self.phase[id-1]
265 self.phase.insert(id-1, phase)
266 # all_blocks = all_blocks + one_block
267 # all_blocks.append(one_block)
268 #Using tx buffer
269 # return all_blocks
246 270
247 271 def __getConnectionStatus(self, cmd, rx_buffer):
248 272
@@ -301,22 +325,52
301 325
302 326 return all_blocks
303 327
328 def __StartingAutomaticControlModules(self):
329
330 #Starting file
331 self.__CreateFile("Monitoring.txt")
332 # data = "MOD.\t BITS\t\t PHASE\n"
333 # self.__writeFile("Monitoring.txt", data)
334 #Starting lists
335 self.txFile = list("------\n------\n------\n" for i in range(64))
336 self.rxFile = list("------\n------\n------\n" for i in range(64))
337 self.bits = list("------\n------\n------\n" for i in range(64))
338 self.phase = list("----- -----\n----- -----\n----- -----\n" for i in range(64))
339
304 340 def __AutomaticControlModules(self):
305 341
306 342 cmd = "ANST"
307 343 rx_buffer = "1"
308 tmp1 = self.__getControlModuleStatus(cmd = cmd, rx_buffer = rx_buffer)
344 self.__getControlModuleStatus(cmd = cmd, rx_buffer = rx_buffer)
309 345
310 346 cmd = "LWPH"
311 347 rx_buffer = "0"
312 tmp2 = self.__getControlModuleLowPhase(cmd = cmd, rx_buffer = rx_buffer)
313 print "getting this: "
314 print tmp1
315 print tmp2
348 self.__getControlModuleLowPhase(cmd = cmd, rx_buffer = rx_buffer)
349 print "Saving file..."
350
351 print self.bits
352 print self.phase
353
354 self.__WritingMonitoringFile()
355
356 threading.Timer(30, self.__AutomaticControlModules).start()
357
358 def __WritingMonitoringFile(self):
359 filename = "Monitoring.txt"
360 data = '===============================' + '\n'
361 self.__writeFile(filename, data)
362 data = time.strftime('\t' + "%d%b%Y %I:%M:%S %p" + '\n', time.localtime())
363 self.__writeFile(filename, data)
364 data = "MOD.\t BITS\t\t PHASE\n"
365 self.__writeFile(filename, data)
366 data = '===============================' + '\n'
367 self.__writeFile(filename, data)
368 for i in range(64):
369 tmp = self.bits[i].split('\n',3)
370 self.__writeFile(filename, ' ' + str(i + 1) + '\t\t' + tmp[2])
371 tmp = self.phase[i].split('\n',3)
372 self.__writeFile(filename, '\t\t' + tmp[2] + '\n')
316 373
317 threading.Timer(30, self.__AutomaticControlModules).start()
318
319
320 374 if __name__ == '__main__':
321 375
322 376 absObj = ABSServer()
General Comments 0
You need to be logged in to leave comments. Login now