##// 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 # self.rx_buffer = "default"
18 # self.rx_buffer = "default"
19 self.rx_buffer = rx_buffer
19 self.rx_buffer = rx_buffer
20 self.enaModules = []
20 self.enaModules = []
21 self.bits = []
22 self.phase = []
23 self.txFile = []
24 self.rxFile = []
21
25
22 self.createObjects()
26 self.createObjects()
23
27
24 print "Checking control modules, please wait ..."
28 print "Checking control modules, please wait ..."
25 self.enaModules = self.checkAntenna()
29 self.enaModules = self.checkAntenna()
26 print "Starting automatic control module status."
30 print "Starting automatic control module status."
31 self.__StartingAutomaticControlModules()
27 self.__AutomaticControlModules()
32 self.__AutomaticControlModules()
28
33
29 def createObjects(self):
34 def createObjects(self):
@@ -87,12 +92,23
87 # f.close()
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 fobj = open(filename,"w")
102 fobj = open(filename,"w")
93 fobj.writelines(data)
103 fobj.writelines(data)
94 fobj.close()
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 def checkAntenna(self):
112 def checkAntenna(self):
97
113
98 """
114 """
@@ -197,7 +213,28
197
213
198 def __getControlModuleStatus(self, cmd, rx_buffer):
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 # enaModules = self.checkAntenna()
238 # enaModules = self.checkAntenna()
202 # enaModules = [11,12,13,14]
239 # enaModules = [11,12,13,14]
203
240
@@ -207,42 +244,29
207
244
208 one_block = self.__ConnectionWithControlModules(rx_buffer,cmd,id)
245 one_block = self.__ConnectionWithControlModules(rx_buffer,cmd,id)
209
246
210 all_blocks = all_blocks + one_block
247 # all_blocks = all_blocks + one_block
211 #Using tx buffer
248 all_blocks.append(one_block)
212
249 #Using tx buffer
213 return all_blocks
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 def __getControlModuleLowPhase(self, cmd, rx_buffer):
252 def __getControlModuleLowPhase(self, cmd, rx_buffer):
232
253
233 all_blocks = ""
254 # all_blocks = ""
234 # enaModules = self.checkAntenna()
255 # all_blocks = []
235 # enaModules = [11,12,13,14]
256 # enaModules = self.checkAntenna()
236
257 # enaModules = [11,12,13,14]
237 for id in range(1,65):
258
238 if id not in self.enaModules:
259 for id in range(1,65):
239 continue
260 if id not in self.enaModules:
240
261 continue
241 one_block = self.__ConnectionWithControlModules(rx_buffer,cmd,id)
262
242
263 phase = self.__ConnectionWithControlModules(rx_buffer,cmd,id)
243 all_blocks = all_blocks + one_block
264 del self.phase[id-1]
244 #Using tx buffer
265 self.phase.insert(id-1, phase)
245 return all_blocks
266 # all_blocks = all_blocks + one_block
267 # all_blocks.append(one_block)
268 #Using tx buffer
269 # return all_blocks
246
270
247 def __getConnectionStatus(self, cmd, rx_buffer):
271 def __getConnectionStatus(self, cmd, rx_buffer):
248
272
@@ -301,22 +325,52
301
325
302 return all_blocks
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 def __AutomaticControlModules(self):
340 def __AutomaticControlModules(self):
305
341
306 cmd = "ANST"
342 cmd = "ANST"
307 rx_buffer = "1"
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 cmd = "LWPH"
346 cmd = "LWPH"
311 rx_buffer = "0"
347 rx_buffer = "0"
312 tmp2 = self.__getControlModuleLowPhase(cmd = cmd, rx_buffer = rx_buffer)
348 self.__getControlModuleLowPhase(cmd = cmd, rx_buffer = rx_buffer)
313 print "getting this: "
349 print "Saving file..."
314 print tmp1
350
315 print tmp2
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 if __name__ == '__main__':
374 if __name__ == '__main__':
321
375
322 absObj = ABSServer()
376 absObj = ABSServer()
General Comments 0
You need to be logged in to leave comments. Login now