APEdev/Executor.py at master · jhardin4/APEdev · GitHub

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
import time
import sys


class executor():
    def __init__(self):
        self.devicelist = {}
        self.log = ''
        self.logaddress = str(int(round(time.time(), 0))) + 'log.txt'
        self.logging = True
        self.debug = False

    def execute(self, eproclist):
        for line in eproclist:
            for eproc in line:
                self.Send(eproc)

    def loadDevice(self, devName, devAddress, devAddressType):
        self.devicelist[devName] = {}
        self.devicelist[devName]['Address'] = devAddress
        self.devicelist[devName]['AddressType'] = devAddressType

    def Send(self, eproc):
        if self.devicelist[eproc['devices']]['AddressType'] == 'pointer':
            if not self.debug:
                try:
                    if eproc['details'] == {}:
                        self.log += getattr(self.devicelist[eproc['devices']]['Address'],
                                            eproc['procedure'])()
                    else:
                        self.log += getattr(self.devicelist[eproc['devices']]['Address'],
                                            eproc['procedure'])(**eproc['details'])

                    self.log += '\n'

                    if self.logging:
                        loghandle = open('Logs/' + self.logaddress, mode='a')
                        loghandle.write(self.log)
                        loghandle.close()
                        self.log = ''

                except Exception:
                    print('The following line failed to send:\n' + str(eproc))
                    print("Oops!", sys.exc_info()[0], "occured.")
                    raise Exception('EXECUTOR SEND FAILURE')

            else:
                if eproc['details'] == {}:
                    self.log += getattr(self.devicelist[eproc['devices']]['Address'],
                                        eproc['procedure'])()
                else:
                    self.log += getattr(self.devicelist[eproc['devices']]['Address'],
                                        eproc['procedure'])(**eproc['details'])

                self.log += '\n'

                if self.logging:
                    loghandle = open('Logs/' + self.logaddress, mode='a')
                    loghandle.write(self.log)
                    loghandle.close()
                    self.log = ''