webCTRLsMAP/webctrl.py at master · UCMAndesLab/webCTRLsMAP · 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
62
63
64
65
66
67
68
69
70
71
72
import os, subprocess
import json
from webctrlSOAP import webctrlSOAP
from smap import actuate, driver
from smap.authentication import authenticated

class _Actuator(actuate.SmapActuator):
   GET_REQUEST = 'getValue'
   SET_REQUEST = 'setValue'

   def setup(self, opts):
      self.devicePath = os.path.expanduser(opts['devicePath'])
      self.serverAddr = opts['webctrlServerAddr'];

      if 'scriptPath' in opts:
         self.scriptPath = opts['scriptPath'];
      else:
         self.webctrl = webctrlSOAP();

   def webctrlRequest(self, typeOfRequest, inputValue = "0"):
      cleanDevicePath = "\"{0}\"".format(self.devicePath)
      print cleanDevicePath;
      if 'scriptPath' in self:
         pythonCmd = [self.scriptPath, typeOfRequest, self.serverAddr, cleanDevicePath, inputValue]
         value = subprocess.check_output(pythonCmd)
      else:
         if typeOfRequest == self.SET_REQUEST:
            value = self.webctrl.setValue(self.serverAddr, self.devicePath, inputValue);
         else:
            value = self.webctrl.getValue(self.serverAddr, self.devicePath);
      return value;


   def get_state(self, request):
      return float(self.webctrlRequest(self.GET_REQUEST));

   def set_state(self, request, state):
      status = self.webctrlRequest(self.SET_REQUEST, str(state));
      if status:
         return float(state);

class WebCTRL_Actuator(_Actuator, actuate.IntegerActuator):
   def setup(self, opts):
      actuate.IntegerActuator.setup(self, opts)
      _Actuator.setup(self, opts)

class WebCtrlDriver(driver.SmapDriver):
   def setup(self, opts):
      zoneSetpoint = []
      zoneSetpoint.append('unoccupied_heating');
      zoneSetpoint.append('unoccupied_cooling');
      zoneSetpoint.append('occupied_heating');
      zoneSetpoint.append('occupied_cooling');


      # List of WebCtrl points/types [Facilities/Bldg1/VAV1_1/] [Damper Position] [double]
      klass = WebCTRL_Actuator
      setpointFile = open(opts['setpointFile'], 'r');
      jsonStr = setpointFile.read();
      setpoints = json.loads(jsonStr);

      for entry in setpoints:
         data_type = 'double'
         for point in zoneSetpoint:
            devicePath = '{0}/{1}/setpoints/{2}.value'.format(entry['refName'], entry['block'], point);
            setup=opts;
            setup['devicePath'] = devicePath;

            actuatorPath = '{0}/{1}'.format(entry['path'], point);
            print actuatorPath
            self.add_actuator(actuatorPath, 'Value', klass, setup=setup, data_type=data_type)