X-Git-Url: http://mj.ucw.cz/gitweb/?a=blobdiff_plain;f=auto%2Fburrow-auto;h=dbcd822e1fea00d35b25dc27c5c834c96f365064;hb=38b7ba69dd4b5d0bc8f9c8b4468f2180e319cb51;hp=1774b8ee70b98d9cbc463a69f2e9e7aa21341364;hpb=2125db97b02973dc88c80a8b33a0525f38471449;p=home-hw.git diff --git a/auto/burrow-auto b/auto/burrow-auto index 1774b8e..dbcd822 100755 --- 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,38 +129,32 @@ 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 - lt = st.get_sensor("temp/loft") - lt_high = st.hysteresis('lt_high', lt, 29, 30) - lt_mid = st.hysteresis('lt_mid', lt, 24, 25) - if lt_high > 0: + lt = st.get_sensor_avg("temp/loft") + out = st.get_sensor_avg('air/outside-intake') + + if lt is None or out is None: + fs = 0 + elif st.hysteresis('lf_out_cold', out, 5, 6) < 0: + fs = 0 + elif st.hysteresis('lf_out_cool', out, 14, 15) < 0: + if st.min in range(10, 15): + fs = 2 + else: + fs = 0 + elif ac_is_on() > 0: + fs = 3 + elif st.hysteresis('lf_loft_hot', lt, 23, 24) > 0: + if st.hysteresis('lf_loft_hotter_than_out', lt, out - 1, out + 1) > 0: fs = 3 - elif lt_mid > 0: - if st.hour in range(10, 20): - fs = 3 else: fs = 1 - else: - if st.hour in range(8, 22): - if st.min % 30 in range(0, 5): - fs = 3 - else: - fs = 0 - else: - fs = 0 - # FIXME: Disabled for now - 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, 23.5, 24) + outside_hot = st.hysteresis('ac_outside_hot', tie, 24, 25) + 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 + need_wait = st.last_ac_change + 300 - st.now # FIXME: Increase + + if need_wait > 0: + action = f"wait({need_wait:.0f})" + 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: