Auto: Air conditioning control

diff --git a/auto/burrow-auto b/auto/burrow-auto
index 1774b8ee70b98d9cbc463a69f2e9e7aa21341364..077022dca6b61e8059fd80512536bc3f86402ac6 100755 (executable)
--- a/auto/burrow-auto
+++ b/auto/burrow-auto
@@ -11,7 +11,7 @@ indent = 0
 
 def debug(msg):
     if debug_mode:
-        print(("\t" * indent) + msg)
+        print(("\t" * indent) + msg, file=sys.stderr)
 
 def diff(x, y):
     if x is None or y is None:
@@ -60,6 +60,12 @@ class State:
         debug("> {} = {}".format(topic, val))
         mq.publish(topic, val, qos=1, retain=True)
 
+    def send(self, key, val):
+        global mq
+        topic = "burrow/" + key
+        debug("> {} := {}".format(topic, val))
+        mq.publish(topic, val, qos=1, retain=False)
+
     def auto_enabled(self, key):
         topic = "burrow/auto/" + key
         if topic in self.attrs:
@@ -123,13 +129,6 @@ class State:
 
 st = State()
 
-def on_connect(mq, userdata, flags, rc):
-    mq.subscribe("burrow/#")
-
-def on_message(mq, userdata, msg):
-    global st
-    # debug("Message {}: {}".format(msg.topic, msg.payload))
-    st.attrs[msg.topic] = msg.payload.decode('utf-8')
 
 def auto_loft_fan():
     global st
@@ -137,10 +136,10 @@ def auto_loft_fan():
     lt_high = st.hysteresis('lt_high', lt, 29, 30)
     lt_mid = st.hysteresis('lt_mid', lt, 24, 25)
     if lt_high > 0:
-            fs = 3
+        fs = 3
     elif lt_mid > 0:
         if st.hour in range(10, 20):
-                fs = 3
+            fs = 3
         else:
             fs = 1
     else:
@@ -155,6 +154,7 @@ def auto_loft_fan():
     fs = 0
     st.set("loft/fan", fs)
 
+
 def auto_circ():
     global st
     if st.hour in range(7, 24):
@@ -163,6 +163,23 @@ def auto_circ():
         c = 0;
     st.set("loft/circulation", c)
 
+
+def ac_is_on():
+    # Heuristics to tell if AC is currently on
+
+    tie = st.get_sensor_avg('air/inside-exhaust')
+    tmix = st.get_sensor_avg('air/mixed')
+    if tie is None or tmix is None:
+        return 0
+
+    # Mixed air is significantly colder than inside exhaust
+    ac_on = -st.hysteresis('ac_off', tmix, tie - 5, tie - 4)
+
+    # FIXME: It might also mean that the loft is cold
+
+    return ac_on
+
+
 def auto_air():
     global st
     tii = st.get_sensor_avg('air/inside-intake')
@@ -171,17 +188,12 @@ def auto_air():
     tmix = st.get_sensor_avg('air/mixed')
     house_warm = st.hysteresis('house_warm', tii, 23.5, 24.5)
     house_hot = st.hysteresis('house_hot', tii, 24.5, 25)
-
-    # Is AC currently on (mixed air is significantly colder than inside exhaust)?
-    if tie is None or tmix is None:
-            ac_off = 1
-    else:
-        ac_off = st.hysteresis('ac_off', tmix, tie - 5, tie - 4)
+    ac_on = ac_is_on()
 
     # XXX: Temporarily disabled
-    house_warm = -1
-    house_hot = -1
-    ac_off = 1
+    #house_warm = -1
+    #house_hot = -1
+    #ac_on = -1
 
     # Do we want to bypass the heat exchanger?
     outside_warmer = st.hysteresis('outside_warmer', diff(toi, tii), -0.5, 0.5)
@@ -195,12 +207,52 @@ def auto_air():
     mixed_warmer = st.hysteresis('mixed_warmer', diff(tmix, tii), -1, 0)
 
     # Do we want to boost heat exchanger fan?
-    if ac_off < 0 or (house_hot > 0 and mixed_warmer < 0):
+    if ac_on > 0 or (house_hot > 0 and mixed_warmer < 0):
         st.set('air/exchanger-fan', 255)
     else:
         st.set('air/exchanger-fan', 0)
 
-    debug("Air: house_warm={} house_hot={} ac_off={} outside_warmer={} mixed_warmer={}".format(house_warm, house_hot, ac_off, outside_warmer, mixed_warmer))
+    debug("Air: house_warm={} house_hot={} ac_on={} outside_warmer={} mixed_warmer={}".format(house_warm, house_hot, ac_on, outside_warmer, mixed_warmer))
+
+
+def auto_aircon():
+    global st
+    tii = st.get_sensor_avg('air/inside-intake')
+    tie = st.get_sensor_avg('air/inside-exhaust')
+    # house_hot = st.hysteresis('ac_house_hot', tii, 24.5, 25)
+    house_hot = st.hysteresis('ac_house_hot', tii, 23, 24)
+    outside_hot = st.hysteresis('ac_outside_hot', tie, 20, 21)
+    ac_on = ac_is_on()
+
+    if house_hot > 0 and outside_hot > 0:
+        want_ac = 1
+    else:
+        want_ac = -1
+
+    if not hasattr(st, 'last_ac_change'):
+        st.last_ac_change = st.now
+
+    if st.last_ac_change >= st.now - 600:
+        action = "wait"
+    elif ac_on == 0:
+        action = "need-data"
+    elif ac_on != want_ac:
+        action = "change"
+        st.send('air/aircon-remote', 'p')
+        st.last_ac_change = st.now
+    else:
+        action = "none"
+
+    debug("AC: house_hot={} outside_hot={} ac_on={} want_ac={} action={}".format(house_hot, outside_hot, ac_on, want_ac, action))
+
+
+def on_connect(mq, userdata, flags, rc):
+    mq.subscribe("burrow/#")
+
+def on_message(mq, userdata, msg):
+    global st
+    # debug("Message {}: {}".format(msg.topic, msg.payload))
+    st.attrs[msg.topic] = msg.payload.decode('utf-8')
 
 opts, args = getopt.gnu_getopt(sys.argv[1:], "", ["debug"])
 for opt in opts:
@@ -222,7 +274,8 @@ time.sleep(3)
 checks = [
     ('loft-fan', auto_loft_fan),
     ('circ', auto_circ),
-    ('air', auto_air)
+    ('air', auto_air),
+    ('aircon', auto_aircon),
 ]
 
 while True:
@@ -230,10 +283,11 @@ while True:
 
     debug("averages")
     indent += 1
-    st.update_average('air/outside-intake', 60)
-    st.update_average('air/inside-intake', 60)
-    st.update_average('air/inside-exhaust', 60)
-    st.update_average('air/mixed', 60)
+    st.update_average('air/outside-intake', 180)
+    st.update_average('air/inside-intake', 180)
+    st.update_average('air/inside-exhaust', 180)
+    st.update_average('air/mixed', 180)
+    st.update_average('temp/loft', 180)
     indent -= 1
 
     for name, func in checks: