A while back people were asking for NeoHub integration, I have a working solution for getting the current temp, checking if heating is on/off and setting the target temp “Setpoint”. It’s all manual setup at first but once it working it works well. I haven’t had any issues with it since i got it working a few months ago.
I’m doing this with a python script and dzvents. I don’t have the programming skills to port this across to the python plugin. Anyone wanting to help it would be much appreciated.
Ill attach my script if anyone is interested in getting Neohub and Domoticz working.
Here’s how to get my solution working;
Copy my python script to the \Domoticz\scripts\python\NeoHubInterface.py folder
• Edit the script with your “Domoticz”:”Port” and “NeoHub IP” details
• Create a dummy hardware device, Call it Neohub for example
oThen create three devices from the NeoHub Hardware per Thermostat.
• Temperature
• Switch
• Thermostat Setpoint
• Now note down all 3 IDX numbers for the Thermostat; Switch, Thermostat & Setpoint
e.g Here is my naming for the devices
Dining Underfloor – Switch Device Name “IDX 1”
Dining Temperature – Temperature Device Name “IDX 2”
Dining - Thermostat Setpoint Name “This Name needs to match the Thermostat name in your neohub app” “IDX 3”
Copy my dzvents LUA script to the \Domoticz\scripts\lua\scripts\ Folder
• Edit the script with your IDX number for the Setpoint Device
• Create a new LUA script for each Thermostat
o The LUA script is a one to one. One script to one Thermostat
• If you have 5 Thermostats then you will have 5 LUA scrpits
Now create a schedule task ie. crontab –e
Add the following
* * * * * /usr/bin/python /home/pi/domoticz/scripts/python/NeoHub.py --StatName '< Thermostat Name>' --Mode http --TempIDX 2 --STempIDX 3 --SwitchIDX 1
This is where we require the 3 IDX numbers noted down earlier;
TempIDX = Temperature
STempIDX = Thermostat Setpoint
SwitchIDX = Switch
NeoHubInterface.py
Code: Select all
#!/usr/bin/python2.7
import json
import socket
import logging
import sys
import getopt
import time
import urllib2
from ConfigParser import SafeConfigParser
import os
#Domoticz IP Address and Port
domoticz = "<DomoticzIP>:<Port>"
#NeoHub IP Address and Port
host = "<NeoHub IP>"
port = "4242"
log = None
def initLogger(name):
global log
logging.basicConfig(filename=os.path.normpath(os.path.dirname(os.path.realpath(__file__)) + "/NeohubInterface" + name + ".log"), level=logging.ERROR, format="%(asctime)s [%(levelname)s] %(message)s")
log = logging.getLogger(__name__)
soh = logging.StreamHandler(sys.stdout)
soh.setFormatter(logging.Formatter("%(asctime)s [%(levelname)s] %(message)s"))
log.addHandler(soh)
log.setLevel(logging.ERROR)
class HeatmiserNeostat:
""" Represents a Heatmiser Neostat thermostat. """
def __init__(self, host, port, name):
self._name = name
self._host = host
self._port = port
self._operation = "Null"
@property
def standby(self):
return self._standby
@property
def deviceResponse(self):
return self._deviceResponse
@property
def should_poll(self):
""" No polling needed for a demo thermostat. """
return True
@property
def name(self):
""" Returns the name. """
return self._name
@property
def operation(self):
""" Returns current operation. heat, cool idle """
return self._operation
@property
def unit_of_measurement(self):
""" Returns the unit of measurement. """
return self._unit_of_measurement
@property
def current_temperature(self):
""" Returns the current temperature. """
return self._current_temperature
@property
def target_temperature(self):
""" Returns the temperature we try to reach. """
return self._target_temperature
@property
def is_away_mode_on(self):
""" Returns if away mode is on. """
return self._away
def set_temperature(self, temperature):
""" Set new target temperature. """
response = self.json_request({"SET_TEMP": [int(temperature), self._name]})
if response:
log.info("set_temperature response: %s " % response)
# Need check for sucsess here
# {'result': 'temperature was set'}
def turn_away_mode_on(self):
""" Turns away mode on. """
log.debug("Entered turn_away_mode_on for device: %s" % self._name)
response = self.json_request({"AWAY_ON":self._name})
if response:
log.info("turn_away_mode_on request: %s " % response)
# Need check for success here
# {"result":"away on"}
# {"error":"Could not complete away on"}
# {"error":"Invalid argument to AWAY_OFF, should be a valid device array of valid devices"}
def turn_away_mode_off(self):
""" Turns away mode off. """
log.info("Entered turn_away_mode_off for device: %s" % self._name)
response = self.json_request({"AWAY_OFF":self._name})
if response:
log.info("turn_away_mode_off response: %s " % response)
# Need check for success here
# {"result":"away off"}
# {"error":"Could not complete away off"}
# {"error":"Invalid argument to AWAY_OFF, should be a valid device or
def turn_frost_mode_off(self):
""" Turns frost mode off. """
log.info("Entered turn_away_mode_off for device: %s" % self._name)
response = self.json_request({"FROST_OFF":self._name})
if response:
log.info("turn_frost_mode_off response: %s " % response)
# Need check for success here
# {"result":"frost off"}
# {"error":"Could not complete frost off"}
# {"error":"Invalid argument to FROST_OFF, should be a valid device or
def turn_frost_mode_on(self):
""" Turns frost mode om. """
log.info("Entered turn_frost_mode_on for device: %s" % self._name)
response = self.json_request({"FROST_ON":self._name})
if response:
log.info("turn_frost_mode_on response: %s " % response)
# Need check for success here
# {"result":"frost on"}
# {"error":"Could not complete frost on"}
# {"error":"Invalid argument to FROST_ON, should be a valid device or
def update(self):
""" Get Updated Info. """
log.debug("Entered update(self)")
response = self.json_request({"INFO": "0"})
if response:
# Add handling for multiple thermostats here
log.debug("update() json response: %s " % response)
counter = 0
deviceResponse = ""
log.debug("Neostats Found:")
for devices in response['devices']:
deviceName = devices['device']
log.debug(str(counter) + ": " + deviceName)
if (deviceName == self.name):
deviceResponse = devices
counter += 1
if (deviceResponse):
#self._name = device['device']
log.info("Neostat Found = " + self.name)
tmptempfmt = deviceResponse["TEMPERATURE_FORMAT"]
if (tmptempfmt is False) or (tmptempfmt.upper() == "C"):
self._unit_of_measurement = "TEMP_CELCIUS"
else:
self._unit_of_measurement = "TEMP_FAHRENHEIT"
log.debug("Temperature Format = " + self.unit_of_measurement)
self.standby = deviceResponse["STANDBY"]
self._away = deviceResponse['AWAY']
self._target_temperature = round(float(deviceResponse["CURRENT_SET_TEMPERATURE"]), 2)
self._current_temperature = round(float(deviceResponse["CURRENT_TEMPERATURE"]), 2)
if (deviceResponse["HEATING"]):
self._operation = "Heating"
elif (deviceResponse["COOLING"]):
self._operation = "Cooling"
else:
self._operation = "Idle"
return False
def printThermostatStatus(self):
log.info("Printing Thermostat Status")
log.info("Name: " + self.name)
log.info("Temperature Format: " + str(self.unit_of_measurement))
log.info("Away: " + str(self.is_away_mode_on))
log.info("Target Temperature: " + str(self.target_temperature))
log.info("Current Temperature: " + str(self.current_temperature))
log.info("Standby: " + str(self.standby))
log.info("Operation: " + self.operation)
def json_request(self, request=None, wait_for_response=False):
""" Communicate with the json server. """
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.settimeout(5)
try:
sock.connect((self._host, self._port))
except OSError:
log.error("Error connecting to Neohub")
sock.close()
return False
if not request:
# no communication needed, simple presence detection returns True
sock.close()
return True
log.debug("json_request: %s " % request)
sock.send(bytearray(json.dumps(request) + "\0\r", "utf-8"))
try:
buf = sock.recv(4096)
except socket.timeout:
# something is wrong, assume it's offline
log.error("Timeout error")
sock.close()
return False
# read until a newline or timeout
buffering = True
while buffering:
if "\n" in str(buf):
response = str(buf).split("\n")[0]
buffering = False
else:
try:
more = sock.recv(4096)
except socket.timeout:
more = None
if not more:
buffering = False
response = str(buf)
else:
buf += more
sock.close()
response = response.rstrip('\0')
log.debug("json_response: %s " % response)
return json.loads(response, strict=False)
def updateDomoticzHttp(domoticzUrl, switchidx, tempidx, stempidx, NeoStat, updateInterval):
while True:
NeoStat.update()
time.sleep(updateInterval)
try:
url = domoticzUrl + "/json.htm?type=command¶m=udevice&idx=" + str(tempidx) + "&nvalue=0&svalue=" + str(
NeoStat.current_temperature)
urllib2.urlopen(url)
log.info("Temperature updated: " + url)
url = domoticzUrl + "/json.htm?type=command¶m=setsetpoint&idx=" + str(stempidx) + "&setpoint=" + str(
NeoStat.target_temperature)
urllib2.urlopen(url)
log.info("SetTemperature updated: " + url)
switchUrl = domoticzUrl + "/json.htm?type=devices&rid=" + switchidx
log.debug("SwitchURL: " + switchUrl)
status = json.load(urllib2.urlopen(switchUrl))['result'][0]['Status']
log.debug("Switch Status: " + status + " - NeoStat Status: " + NeoStat.operation)
if status == "Off" and NeoStat.operation == "Heating":
switchOnUrl = domoticzUrl + "/json.htm?type=command¶m=switchlight&idx=" + str(switchidx) + "&switchcmd=On"
log.info("Turn Switch " + str(switchidx) + " On")
urllib2.urlopen(switchOnUrl)
elif status == "On" and NeoStat.operation == "Idle":
switchOffUrl = domoticzUrl + "/json.htm?type=command¶m=switchlight&idx=" + str(
switchidx) + "&switchcmd=Off"
log.info("Turn Switch " + str(switchidx) + " Off")
urllib2.urlopen(switchOffUrl)
if (updateInterval == 0):
break
except socket.timeout, e:
log.error("Timeout error occurred retrieving NeoStat data...")
except urllib2.HTTPError, e:
log.error("HTTP error - " + e)
except urllib2.URLError, e:
log.error("URL Error - " + e)
except:
log.error("Error Occurred...")
def main(argv):
try:
opts, args = getopt.getopt(argv, "hsfix:", ["StatName=", "Mode=", "TempIDX=", "STempIDX=", "SwitchIDX="])
except getopt.GetoptError:
print("NeoHubInterface.py -h -s -f -i -x --StatName --Mode --TempIDX --STempIDX --SwitchIDX")
sys.exit(1)
updateMode = True
updateInterval = 0
for opt, arg in opts:
if opt in '-h':
print("NeoHubInterface.py -h -s -f -i -x --StatName --Mode --TempIDX --STempIDX --SwitchIDX")
sys.exit(2)
elif (opt == "--StatName"):
statName = arg
elif (opt == "--TempIDX"):
tempidx = int(arg)
elif (opt == "--STempIDX"):
stempidx = int(arg)
elif (opt == "--SwitchIDX"):
switchidx = arg
elif (opt == "--Mode"):
mode = arg
elif (opt == "-i"):
updateInterval = float(arg)
elif (opt == "-s"):
updateMode = False
elif (opt == "-x"):
set = float(arg)
initLogger(statName)
log.info("NeoHub connection: " + host + ":" + str(port))
NeoStat = HeatmiserNeostat(host, int(port), statName)
if updateMode:
if mode == "http":
log.debug("HTTP Mode")
updateDomoticzHttp(domoticz, switchidx, tempidx, stempidx, NeoStat, updateInterval)
elif not updateMode:
if (set):
NeoStat.set_temperature(int(set))
log.info("Exiting...")
main(sys.argv[1:])
Code: Select all
return {
active = true,
on = {
3 -- Setpoint Device IDX Number
},
data = {
previousTemp = { initial = 20 }
},
execute = function(domoticz, device)
local previousTemp = domoticz.data['previousTemp']
local TargetTemp = device.setPoint;
if (TargetTemp ~= previousTemp) then
-- send the TargetTemp to NeoHub
os.execute('python /home/pi/domoticz/scripts/python/NeoHubInterface.py -s -x '..TargetTemp..' --StatName '.."'"..device.name.."'")
end
-- domoticz.log(device.name, domoticz_LOG_INFO)
-- domoticz.log(device.deviceType, domoticz_LOG_INFO)
-- domoticz.log(TargetTemp, domoticz_LOG_INFO)
-- domoticz.log(previousTemp, domoticz_LOG_INFO)
-- domoticz.log('python /home/pi/domoticz/scripts/python/NeoHubInterface.py -s -x '..tonumber(TargetTemp)..' --StatName '.. "'"..device.name.."'")
domoticz.data['previousTemp'] = TargetTemp
-- domoticz.logDevice(device)
end
}
. Thank you. I have a first gen heatmiser hub. Maybe that has something to do with it. 