Code : Tout sélectionner
#!/usr/bin/python
# domo2vito
# JS MARTIN# version 2.11 - 07-03-2017
# version 2.20 - hestia - 31-03-2019:
# add starts (number of starts of the burner), incremental boiler-runtime in hx100
# use update_device_status function, get_last_user_variable_value and set_user_variable_value
# consumption calculation in kWh and new calculation for gaz in m3
# parameter to calulate consumption only (more often to get accuracy results)
# update Domoticz with reduced time info
# version 2.30 - hestia - 23/07/2020:
# upload vitalk status in domoticz (vitalk_error_log)
# remove old consumption calculation method in m3
# modify incremental boiler-runtime in hx100 to incremental boiler-runtime in h with decimal due to max in domoticz
# upload Vitalk errors in Domoticz
# version 2.31 - hestia - 17/08/2020
# update 'delta_rt' in Domoticz optionnal
# version 2.40 - hestia - 09/09/2020
# update vitalk status at the end if ok instead of the begining
# version 2.41 - hestia - 01/04/2022
# remove decimal for consumption counter in m3 and kWh
# version 2.42 - hestia - 08/01/2023
# if there was a stop delta_rt is big and there will be an abnormal comsuption value, so delta_rt set to 0
# version 2.50 - hestia - 02/02/2023
# WARNING: from Beta build 2022.2 build 14708 and up API URLs with username and password as parameters are not supported anymore!!
# Use https://username:password@IP:PORT/json.htm instead.
# set the IP in dz setting instead
# requests.get(req,auth=HTTPBasicAuth(user,password)) -> requests.get(req)
# version 2.51 - hestia - 22/04/2023
# Cleaning and comment 02/02/2023's change
import telnetlib
import sys
import os
import time
import datetime
import requests
#from requests.auth import HTTPBasicAuth # 22/04/2023
import json
#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
# Mode log_Info
#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
log_Info=True # basic info about execution
log_Detail=False #False # more info about execution
if log_Info:
print 'Start '+time.strftime("%H")+':'+time.strftime("%M")
from timeit import default_timer as timer
startTimer = timer()
############# Parameters #################################
#~~~~~~~~~~ Parameters Domoticz ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
domoticz_ip='xxxx' #IP or DNS
domoticz_port='8080'
#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
# Commands viTalk and Addresses
#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
#autorized commands
commands = ["mode","saving","party","party_soll_temp","outdoor_temp","raum_soll_temp","raum_ist_temp","k_ist_temp","ww_soll_temp","ww_ist_temp","k_abgas_temp","power","errors","runtime","red_raum_soll_temp", "starts"]
#write only commands
write_only_commands = ["mode","saving","party","party_soll_temp","ww_soll_temp","red_raum_soll_temp","raum_soll_temp"]
#commands for consumption calculation
consumption_commands = ["power","runtime"] #, "starts"] # commented if necessary in the future
# addresses for reduce mode time intervals
V_addresses=["2000","2008", "2010", "2018", "2020", "2028", "2030"]
#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
# IDX de Domoticz
#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
# widget to create, idx to set
dummy_idx={'mode':346, 'saving':347, 'party':348, 'party_soll_temp':349, 'outdoor_temp':350, 'raum_soll_temp':351, 'raum_ist_temp':352, 'k_ist_temp':353, 'ww_soll_temp':354, 'ww_ist_temp':355, 'k_abgas_temp':356, 'power':357, 'boiler_error_log':358, 'problem':359, 'delta_rt': "", 'delta_incr_rt': 1189, 'gasLiter':431, 'red_raum_soll_temp':362, 'holiday_temp':363, 'raum_soll_temp_W':364, 'incr_starts':393, 'gaskWh':432, 'reduce_mode':427, 'vitalk_error_log':1187}
# 0 mode : dummy selector switch OFF/Water/Heating (Boiler [FR:chaudiere] stand-by/water only/water+heating) {read/write}
# 1 saving : dummy switch ON/OFF (Boiler eco ON/OFF) {read/write}
# 2 party : dummy switch ON/OFF (party temporary manual control) - note : party ON does not work (vitalk bug ?) {read/write}
# 3 party_soll_temp : dummy thermostat setpoint (party temperature) {write only}
# 4 outdoor_temp : dummy temp (outdoor temperature) {read only}
# 5 raum_soll_temp : dummy temp (heating [FR:consigne] temperature ) {read only} - note : without vitotronic, you could use thermostat setpoint
# 6 raum_ist_temp : dummy temp (heating current [FR:actuelle] temperature) {read only}
# 7 k_ist_temp : dummy temp (boiler current temperature) {read only}
# 8 ww_soll_temp : dummy thermostat setpoint (hot water setpoint temperature) {write only}
# 9 ww_ist_temp : dummy temp (hot water current temperature) {read only}
#10 k_abgas_temp : dummy temp (exhaust gas [FR:gaz evacue'] temperature) {read only}
#11 power : dummy percentage (% boiler power) {read only}
#12 boiler_error_log : dummy alert (show the two last log codes) {read only}
# problem : dummy switch (set switch to On if there is a internal boiler problem)
#13 runtime : dummy custom sensor [seconds] (delta_rt) (Operating time of boiler since last script call) {read only}
# to leave blank to avoid update in Domoticz
# runtime : dummy incremental counter sensor (delta_incr_rt) [hours with decimals]
# gasLiter : dummy incremental counter [gas] (Estimation of Gas consumption)
# /!\ Counter Dividers to set to 1000 on the device to get gas in liter
# gaskWh : dummy incremental counter [gas] (Estimation of kW.h consumption)
#14 red_raum_soll_temp: dummy thermostat setpoint (reduced temperature) {write only}
# holiday_temp : dummy thermostat setpoint (holiday temperature)
# raum_soll_temp_W : dummy thermostat setpoint (normal temperature) {write only} - note: does not work with vitotrol 300
# for raum_soll_temp_W, you need to put the bolean Use_normal_temperature_setpoint to True
#15 incr_starts : dummy incremental counter (number of starts of the burner) {read only}
# reduce_mode : dummy selector switch Reduced/Normal according to normal times slot set in the boiler (calculated)
# vitalk_error_log : dummy alert
# User variables:
# boilerRuntime [integer]:overall boiler time in seconds persistance
# boilerKWhToM3 [float]: coeff to convert kW.h to gas m3 (to get from your gas provider)
# boilerPowerAjust [float]: coeff to adjust consumption calculation (due to error about power of the boiler, others...)
# boilerPowerAverage [float]: boiler power moving average persistance
user_idx={'boilerRuntime':6, 'boilerKWhToM3':3, 'boilerPowerAjust':4, 'boilerPowerAverage':5}
#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
# Variable
#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
#Boiler power
BoilerPower=26 #Max power of the boiler in kW
# Activated normal temperature setpoint
Use_normal_temperature_setpoint=True
########################################################################
###### update_device_status(idx, nval, sval) : update current value for the device
########################################################################
def update_device_status(idx, nval, sval):
if log_Detail:
print "update_device_status idx: " +idx+ " nval: " +str(nval)+ " sval: " +sval
req='http://'+domoticz_ip+':'+domoticz_port+'/json.htm?type=command¶m=udevice&idx='+idx+'&nvalue='+str(nval)+'&svalue='+sval
requests.get(req)
####
########################################################################
###### update_alert(alertId, alertMsg, alertLevel) : update alert
########################################################################
def update_alert(alertId, alertMsg, alertLevel):
update_device_status(str(dummy_idx[alertId]), alertLevel, alertMsg)
if log_Detail:
print "update_alert: " +alertId+ " " +alertMsg+ " " +alertLevel
####
#######################################################################
###### viTalk_connect() : connect to viTalk localhost:83
#######################################################################
def viTalk_connect():
global log_Info
retry=3
while retry!=0:
try:
tn = telnetlib.Telnet("localhost", 83)
if log_Info:
print "Connected to viTalk telnet!"
#err_text='Connection OK'
#print err_text
#update_alert('vitalk_error_log', err_text, 1)
return tn
except:
print "ERROR viTalk_connect - I try to restart viTalk deamon"
#I try to restart viTalk
cmd = 'sudo service vitalk restart'
os.system(cmd)
time.sleep(10)
retry-=1
else:
tn.read_until(b"$", 5)
if retry==0:
print "ERROR viTalk_connect - I could not restart viTalk deamon"
V_previous_vitalk_error_level=get_device_value((str(dummy_idx['vitalk_error_log'])), "Level")
#print "V_previous_vitalk_error_level "+str(V_previous_vitalk_error_level)
if V_previous_vitalk_error_level<4:
slevel=V_previous_vitalk_error_level+1
else:
slevel=4
update_alert('vitalk_error_log', 'ERROR viTalk_connect #'+str(slevel-1), 4)
#tn.close() ## 24/07/2020 comentec to avoid " tn.close() UnboundLocalError: local variable 'tn' referenced before assignment"
sys.exit()
####
#######################################################################
###### viTalk_read(cmd) : read a value
#######################################################################
def viTalk_read(cmd):
global log_Info
global tn
retry=5
value=""
while retry!=0:
tn.read_until(b"$", 5)
if log_Detail: print "cmd="+cmd
tn.write(b"g "+cmd+"\n")
value=tn.read_until(b"$", 5).strip("\n$")
if value!="" and value!='NULL':
break
retry-=1
if retry==0:
print "ERROR viTalk_read - I try to restart viTalk deamon"
update_alert('vitalk_error_log', 'ERROR viTalk_read', 4)
os.system('sudo service vitalk restart')
#tn.close()
print(cmd+": "+value+" error")
sys.exit()
value = value.strip("\n$")
if log_Info:
print "get "+cmd+" : answer = "+value
return value
####
#######################################################################
###### viTalk_read_address(addr) : read the value of an address
#######################################################################
def viTalk_read_address(addr):
global log_Info
global tn
retry=3
value=""
while retry!=0:
tn.read_until(b"$", 5)
tn.write(b"rg "+addr+"\n")
value=tn.read_until(b"$", 5).strip("\n$")
if value!="" and value!='NULL':
break
retry-=1
if retry==0:
print "ERROR viTalk_read_address - I try to restart viTalk deamon"
update_alert('vitalk_error_log', 'ERROR viTalk_read_address', 4)
os.system('sudo service vitalk restart')
#tn.close()
print(addr+": "+value+" error")
sys.exit()
value = value.strip("\n$")
if log_Detail:
print "read address "+addr+" : answer = "+value
return value
####
#######################################################################
###### viTalk_check() : test viTalk and restart it if needed
#######################################################################
def viTalk_check():
global log_Info
global tn
retry=3
value=""
while retry!=0:
tn.read_until(b"$", 5)
tn.write(b"g saving \n")
value=tn.read_until(b"$", 5).strip("\n$")
if value!="" and value!='NULL':
if log_Info:
print "Check viTalk data OK ! (no NULL data received)"
break
retry-=1
if retry==0:
print "ERROR viTalk_check - I try to restart viTalk deamon"
update_alert('vitalk_error_log', 'ERROR viTalk_check', 4)
os.system('sudo service vitalk restart')
sys.exit()
####
#######################################################################
###### viTalk_set(cmd,val) : unsecured write
#######################################################################
def viTalk_set(cmd,val):
global log_Info
global tn
if cmd!="mode":
tn.write(b"s "+cmd+" "+val+"\n")
else: # vitalk does not manage mode 3 and 4 => raw set directly
tn.write(b"rs 2323 "+val+"\n")
tn.read_until(b"$", 5).strip("\n$")
if log_Info: print("set "+cmd+" "+val)
####
#######################################################################
###### viTalk_write(cmd,val) : secured write (I check if value is
###### really
#######################################################################
def viTalk_write(cmd,val):
global log_Info
global tn
retry=3
value=""
while retry!=0:
viTalk_set(cmd,val)
tn.read_until(b"$", 5)
time.sleep(1)
value=viTalk_read(cmd)
if val==value:
break
retry-=1
if retry==0:
tn.close()
print(cmd+" "+val+" : error")
sys.exit()
if log_Info:
print "check last command set "+cmd+" "+val+" : OK"
####
#######################################################################
###### check_command(cmd) : is it an authorized command ?
#######################################################################
def check_command(cmd):
global commands
global log_Info
try:
#check position of cmd in commands list
commands.index(cmd)
except:
print "command not found"
return False
else:
if log_Info:
print "this command "+cmd+" is known"
return True
####
#######################################################################
###### check_set_command(cmd) : is it an authorized write command ?
#######################################################################
def check_set_command(cmd):
global commands
global log_Info
try:
#check position of cmd in write only commands list
write_only_commands.index(cmd)
except:
print "set command not found (I can't write with this command)"
return False
else:
if log_Info:
print "this command "+cmd+" is known for writing"
return True
####
########################################################################
###### get_device_status(idx) : get current value for the device
########################################################################
def get_device_status(idx):
r = requests.get('http://'+domoticz_ip+':'+domoticz_port+'/json.htm?type=devices&rid='+str(idx))
status=r.status_code
if status == 200:
r=r.json()
result={}
return r['result'][0]['Data']
else:
print "Get device status - IDX:"+str(idx)+" not found ?"
####
########################################################################
###### update_device_switch(idx, cmd) : update switch device to domoticz
########################################################################
def update_device_switch(idx, cmd):
if log_Detail:
print "update_device_switch idx: " +idx+ " cmd: " +cmd
req='http://'+domoticz_ip+':'+domoticz_port+'/json.htm?type=command¶m=switchlight&idx='+idx+'&switchcmd='+cmd
requests.get(req)
####
########################################################################
###### get_last_user_variable_value(idx) : get last value from domoticz
########################################################################
def get_last_user_variable_value(idx):
r = requests.get('http://'+domoticz_ip+':'+domoticz_port+'/json.htm?type=command¶m=getuservariable&idx='+str(idx))
status=r.status_code
if status == 200:
r=r.json()
result={}
return r['result'][0]['Value']
else:
print "Get last user variable value error - IDX:"+str(idx)
####
########################################################################
###### set_user_variable_value(idx, vname, vval) : set user varialbe value to domoticz
########################################################################
def set_user_variable_value(idx, vname, vval):
if log_Detail:
print "set_user_variable_value idx: " +idx+ " vname: " +vname+ " vval: "+vval
req='http://'+domoticz_ip+':'+domoticz_port+'/json.htm?type=command¶m=updateuservariable&idx='+idx+'&vname='+vname+'&vtype=0&vvalue='+vval
requests.get(req)
###
########################################################################
###### get_device_value(idx) : get current value of a name for the device
########################################################################
def get_device_value(idx, name):
r = requests.get('http://'+domoticz_ip+':'+domoticz_port+'/json.htm?type=devices&rid='+str(idx))
status=r.status_code
if status == 200:
r=r.json()
result={}
#print "get_device_value"
#print r['result'][0][name]
#print "get_device_value END"
return r['result'][0][name]
else:
print "Get device value - name " +name+" IDX:"+str(idx)+" not found ?"
####
#-----------------------------------### START ###--------------------------------------------#
# arguments in command line
nb_arg=len(sys.argv)-1
if nb_arg==0:
print "HELP : "
print "domo2vito gas : update boiler consumption in domoticz"
print "domo2vito update : update all domoticz values except boiler consumption"
print "domo2vito update+gas : update all domoticz values"
print "domo2vito command : get command (e.g. domo2vito mode <=> get mode)"
print "domo2vito command value : set command value (e.g. domo2vito mode 1 <=> set mode 1)"
print "--> supported commands :"
for command in commands:
print " - "+command
if nb_arg==1 and sys.argv[1]!="update" and sys.argv[1]!="gas" and sys.argv[1]!="update+gas":
if check_command(sys.argv[1]):
if log_Info:
print "get "+sys.argv[1]
tn=viTalk_connect()
viTalk_read(sys.argv[1])
tn.close()
#-------------------------------## Gas consumption calculation only ##---------------------------#
if nb_arg==1 and (sys.argv[1]=="gas" or sys.argv[1]=="update+gas"):
tn=viTalk_connect()
viTalk_check()
values=[]
i=0
tn.read_until(b"$", 5)
for command in consumption_commands:
tn.write(b"g "+command+"\n")
value=tn.read_until(b"$", 5).strip("\n$")
if log_Info:
print str(i)+") command : get "+command+ " => "+value
if value=="" or value=='NULL':
err_text=command+" NULL"
print err_text
update_alert('vitalk_error_log', err_text, 2)
sys.exit()
values.append(value)
i+=1
if log_Info: print "+Gas consumption calculation since last script call:"
# Get previous boiler runtime value from Domoticz database (user variable)
last_rt_string=get_last_user_variable_value(user_idx['boilerRuntime'])
print "last_rt_string="+last_rt_string
last_rt=int(get_last_user_variable_value(user_idx['boilerRuntime']))
delta_rt=int(values[1])-last_rt # delta_runtime in seconds
# Update boiler-runtime since last update ("basic" in seconds), if device id filled, to leave blank if not needed
if dummy_idx['delta_rt'] !="" and dummy_idx['delta_rt']!='NULL':
update_device_status(str(dummy_idx['delta_rt']),0, str(delta_rt))
last_rt_h=float(get_device_status(dummy_idx['delta_incr_rt']))
present_runtime=float(values[1])/3600
delta_rt_h=(present_runtime - last_rt_h) # seconds to hours with decimals
if log_Info:
print "last runtime h: "+str(last_rt_h)
print "present runtime : "+values[1]+ " seconds "+str(present_runtime)+" h"
print "delta runtime h: "+str(delta_rt_h)
# Update boiler-runtime since last update (incremental in hours with decimals
update_device_status(str(dummy_idx['delta_incr_rt']),0, str(delta_rt_h))
# Set overall boiler runtime into Domoticz database (user variable)
set_user_variable_value(str(user_idx['boilerRuntime']), 'boilerRuntime', values[1])
param_boilerKWhToM3=float(get_last_user_variable_value(user_idx['boilerKWhToM3']))
param_boilerPowerAjust=float(get_last_user_variable_value(user_idx['boilerPowerAjust']))
if log_Detail:
print 'boilerKWhToM3: ' +str(param_boilerKWhToM3)
print 'boilerPowerAjust: ' +str(param_boilerPowerAjust)
# Get previous starts value from Domoticz database (user variable)
# commented => in the Update part
#last_st=int(get_device_status(dummy_idx['incr_starts']))
#delta_st=int(values[2])-last_st # delta starts
# Update starts since last update
#update_device_status(str(dummy_idx['incr_starts']),0, str(delta_st))
# Get previous power and moving average from Domoticz database (user variable)
# power: dummy percentage (% boiler power)
previous_power_value=float(get_device_status(dummy_idx['power'])[:-1]) # on supprime le % a la fin de la chaine
if log_Detail: print 'previous_power_value= '+str(previous_power_value)
moving_avg_power=float(get_last_user_variable_value(user_idx['boilerPowerAverage']))
# Update power to Domoticz widget
Vpower=float(values[0])
update_device_status(str(dummy_idx['power']),0, str(Vpower))
if Vpower <> 0:
moving_avg_power_new=int(round((moving_avg_power+Vpower)/2,0))
if log_Detail: print "update moving average: " +str(moving_avg_power_new)
set_user_variable_value(str(user_idx['boilerPowerAverage']), 'boilerPowerAverage', str(moving_avg_power_new))
# 08/01/2023: If there was a stop delta_rt is big and there will be an abnormal comsuption value, so delta_rt set to 0
if delta_rt > 3600:
print "delta_rt "+str(delta_rt)+" > 3600 => set to 1"
delta_rt=1
#print "delta_rt "+str(delta_rt)
# Comsuption estimation for gas in W.h
Wh_used=0
CalPower=0.
if delta_rt > 0:
# The power value to calculate the consumption is the higher between the current one and the previous one
CalPower=max(Vpower, previous_power_value)
if CalPower==0:
CalPower=moving_avg_power # the heating was between 2 runs of the script, we use the moving average instead of 0
if log_Info: print "short heating cycle => moving average " +str(moving_avg_power)
else:
if log_Info: print "heating cycle => max current " +str(Vpower) +" previous power: " +str(previous_power_value)
# Comsuption estimation for gas in energy W.h:
# the duration of the heating (h) : ex 35 seconds => 35 / 3600 h
# x the boiler power (kW) : 26 kW = 26 x 1000 W
# x a parametrer to adjust the boiler power or the imprecison of the power measur : ex 1
# x the power of the heating in % : ex 28,5%
# = 72,04167 W.h
Wh_used=delta_rt/3.6*BoilerPower*param_boilerPowerAjust*CalPower/100
# Comsuption estimation for gas in liters:
# Comsuption in W.h / coeff kW.h to m3 (https://www.grdf.fr/particuliers/services-gaz-en-ligne/coefficient-conversion)
# kW.h to m3 == W.h to L
gas_used_liter=Wh_used/param_boilerKWhToM3 # see RFXMeter/Counter Dividers in Domoticz Setup ; I set 1000 to get gas in liter
gas_used_liter=int(round(gas_used_liter)) # 01/04/2022
Wh_used=int(round(Wh_used)) # 01/04/2022
if log_Info:
print "Runtime;VPower;Wh;GazL;MobAvg"
print "Conso " + str(delta_rt) +";" +str(Vpower) +";" +str(Wh_used) +";" +str(gas_used_liter) +";" +str(moving_avg_power)
if log_Detail:
print " -Runtime (sec) = "+str(delta_rt)
#print " -Start (nb) = "+ str(delta_st)
print " -Estimated Wh used = " +str(Wh_used)
print " -Estimated gas used (liter) = " +str(gas_used_liter)
# Update gas in Domoticz
# Update kw.h
update_device_status(str(dummy_idx['gaskWh']),0, str(Wh_used))
# Update gas (m3)
update_device_status(str(dummy_idx['gasLiter']),0, str(gas_used_liter))
#----------------------------## Update w/o or w consumption calculation ##------------------------#
if nb_arg==1 and (sys.argv[1]=="update" or sys.argv[1]=="update+gas"):
tn=viTalk_connect()
viTalk_check()
values=[]
i=0
tn.read_until(b"$", 5)
for command in commands:
tn.write(b"g "+command+"\n")
value=tn.read_until(b"$", 5).strip("\n$")
if log_Info:
print str(i)+") command : get "+command+ " => "+value
if value=="" or value=='NULL':
err_text=command+" NULL"
print err_text
update_alert('vitalk_error_log', err_text, 2)
sys.exit()
values.append(value)
i+=1
if log_Detail: print "+Now I check if I need to update some values into Viessmann boiler or into Domoticz..."
mcur=time.localtime().tm_min # to update setpoint one time every hour - get minute of current hour
if mcur>40 and mcur<56: # Heartbeat - update setpoint in Domoticz one time per hour just to avoid "lost widget status"
setpoint_heartbeat=True
else:
setpoint_heartbeat=False
# party_soll_temp : get setpoint party_soll_temp and update boiler if needed
temp=int(float(get_device_status(dummy_idx['party_soll_temp'])))
if temp!=int(float(values[3])): #Viessmann ignore decimales
if temp<10: temp=10 # party mini temp
if temp>30: temp=30 # party maxi temp
if log_Info: print "3) party setpoint has changed : I update Viessmann boiler with party temperature = "+str(temp)
viTalk_set("party_soll_temp",str(temp))
else:
if setpoint_heartbeat:
update_device_status(str(dummy_idx['party_soll_temp']),0, str(temp))
# get setpoint ww_soll_temp and update boiler if needed
temp=int(float(get_device_status(dummy_idx['ww_soll_temp'])))
if temp!=int(float(values[8])): #Viessmann ignore decimales
if temp<20: temp=20 # hot water mini temp
if temp>70: temp=70 # hot water maxi temp
if log_Info: print "8) hot water setpoint has changed : I update Viessmann boiler with hot water temperature = "+str(temp)
viTalk_set("ww_soll_temp",str(temp))
else:
if setpoint_heartbeat:
update_device_status(str(dummy_idx['ww_soll_temp']),0, str(temp))
# holiday mode : emulated* holiday mode *I put boiler in permanent reduce mode with a custom holiday temp
if int(values[0])==3: # mode 'permanent reduce'
if log_Info: print "Holiday mode : I check if reduced temp. = domoticz holiday setpoint temp."
temp=int(float(get_device_status(dummy_idx['holiday_temp'])))
if temp!=int(float(values[14])):
if temp<10: temp=10 # holidays mini temp
if temp>30: temp=30 # holidays maxi temp
viTalk_set("red_raum_soll_temp",str(temp)) # Reduced temp = domoticz holiday temp
if log_Info: print "- I update reduced temperature with domoticz holiday setpoint temperature"
else:
# get setpoint red_raum_soll_temp and update boiler if needed
if log_Info: print "Not Holiday mode : I check if reduced temp. = domoticz reduced setpoint temp."
temp=int(float(get_device_status(dummy_idx['red_raum_soll_temp'])))
if temp!=int(float(values[14])): #Viessmann ignore decimales
if temp<10: temp=10 # reduced mini temp
if temp>30: temp=30 # reduced maxi temp
if log_Info: print "14) Reduced temp setpoint has changed : I update Viessmann boiler with reduced temperature = "+str(temp)
viTalk_set("red_raum_soll_temp",str(temp))
if Use_normal_temperature_setpoint:
if log_Info: print "Use_normal_temperature_setpoint => activated"
temp=int(float(get_device_status(dummy_idx['raum_soll_temp_W'])))
if temp!=int(float(values[5])): #Viessmann ignore decimales
if temp<10: temp=10 # reduced mini temp
if temp>30: temp=30 # reduced maxi temp
if log_Info: print "15) Normal temp setpoint has changed : I update Viessmann boiler with normal temperature = "+str(temp)
viTalk_set("raum_soll_temp",str(temp))
if setpoint_heartbeat:
temp=int(float(get_device_status(dummy_idx['holiday_temp'])))
if temp<10: temp=10 # holidays mini temp
if temp>30: temp=30 # holidays maxi temp
update_device_status(str(dummy_idx['holiday_temp']),0, str(temp))
temp=int(float(get_device_status(dummy_idx['red_raum_soll_temp'])))
if temp<10: temp=10 # reduced mini temp
if temp>30: temp=30 # reduced maxi temp
update_device_status(str(dummy_idx['red_raum_soll_temp']),0, str(temp))
if Use_normal_temperature_setpoint:
temp=int(float(get_device_status(dummy_idx['raum_soll_temp_W'])))
if temp<10: temp=10 # normal mini tempraum_soll_temp_W
if temp>30: temp=30 # normal maxi temp
update_device_status(str(dummy_idx['raum_soll_temp_W']),0, str(temp))
# mode (selector level : 0=OFF 10=water 20=heating 30=holidays 40=always On)
previous_value=get_device_status(dummy_idx['mode'])
if previous_value=="Off": previous_value="Set Level: 0 %"
if int(previous_value[11:-1])!=int(values[0])*10:
if log_Info: print "0) Value MODE has changed : I update domoticz with mode = "+values[0]
update_device_switch(str(dummy_idx['mode']), 'Set%20Level&level='+str(int(values[0])*10))
# saving : dummy switch ON/OFF (Boiler eco ON/OFF) : if a user modify boiler or vitotrol, update Domoticz
previous_value=get_device_status(dummy_idx['saving'])
if (previous_value=="On" and values[1]=="0") or (previous_value=="Off" and values[1]=="1"):
if log_Info: print "1) Value SAVING has changed : I update domoticz with saving = "+values[1]
if values[1]=="0":
update_device_switch(str(dummy_idx['saving']), 'Off')
else:
update_device_switch(str(dummy_idx['saving']), 'On')
# party : dummy switch ON/OFF (party temporary manual control) : if a user modify boiler or vitotrol, update Domoticz
previous_value=get_device_status(dummy_idx['party'])
if (previous_value=="On" and values[2]=="0") or (previous_value=="Off" and values[2]=="1"):
if log_Info: print "2) Value PARTY has changed : I update domoticz with party = "+values[2]
if values[2]=="0":
update_device_switch(str(dummy_idx['party']), 'Off')
else:
update_device_switch(str(dummy_idx['party']), 'On')
# outdoor_temp : dummy temp (outdoor temperature)
update_device_status(str(dummy_idx['outdoor_temp']),0, values[4])
# raum_soll_temp : dummy temp (heating setpoint [FR:consigne] temperature) - note : without vitotronic, use thermostat setpoint
update_device_status(str(dummy_idx['raum_soll_temp']),0, values[5])
# raum_ist_temp : dummy temp (heating current [FR:actuelle] temperature)
update_device_status(str(dummy_idx['raum_ist_temp']),0, values[6])
# k_ist_temp : dummy temp (boiler current temperature)
update_device_status(str(dummy_idx['k_ist_temp']),0, values[7])
# ww_ist_temp : dummy temp (hot water current temperature)
update_device_status(str(dummy_idx['ww_ist_temp']),0, values[9])
# k_abgas_temp : dummy temp (exhaust gas [FR:gaz evacue'] temperature)
update_device_status(str(dummy_idx['k_abgas_temp']),0, values[10])
# Get previous starts value from Domoticz database (user variable)
last_st=int(get_device_status(dummy_idx['incr_starts']))
delta_st=int(values[15])-last_st # delta starts
# Update starts since last update
update_device_status(str(dummy_idx['incr_starts']),0, str(delta_st))
if log_Detail: print " -Start (nb) = "+ str(delta_st)
# time calculation according to Viessanmm coding retrieve via vitalk
V_time=(int(time.strftime("%H"))*8+int(time.strftime("%M"))/10)
if log_Detail: print "V_time: "+str(V_time)
# normal time? Test if the boiler is inside a normal times slot (and not reduced slot)
# Num of the week to retrieve the schedule of the day
daynum=datetime.datetime.today().weekday()
# Addresses for reduce mode time intervals
adr_i=V_addresses[daynum]
if log_Detail: print "day#: "+str(daynum)+" viTalk_read_address..."+adr_i
time_interval=viTalk_read_address(V_addresses[daynum]+" 8")
tn.close()
time_intervals=""
time_intervals_list=time_interval.split(';')
i=0
time_inside=False
while i<8:
if log_Detail: print str(i) +" ; " +str(time_intervals_list[i]) +" ; " +str(V_time) +" ; " +str(time_intervals_list[i+1])
if int(time_intervals_list[i]) <= V_time and V_time < int(time_intervals_list[i+1]):
time_inside=True
break
i+=2
if log_Detail: print "Time inside normal interval? " +str(time_inside)
previous_value=get_device_status(dummy_idx['reduce_mode'])
if log_Detail: print "previous_value normal/reduced: "+previous_value
if (previous_value=="Off" and time_inside):
if log_Info: print "Time changed to normal slot: I update domoticz"
update_device_switch(str(dummy_idx['reduce_mode']), 'Set%20Level&level=10')
elif (previous_value!="Off" and not time_inside):
if log_Info: print "Time changed to reduce slot: I update domoticz"
update_device_switch(str(dummy_idx['reduce_mode']), 'Set%20Level&level=0')
if log_Info: print "+Now I check boiler error..."
# boiler_error_log : dummy alert (show the two last log codes)
# problem : dummy switch (set switch to On if there is a internal boiler problem)
#values[12]="123,255,235,244,244,244,244,244,244,244 ;"
V_error=values[12][0:3]
V_previous_error=values[12][4:7]
V_error_hexa=str(hex(int(V_error)))[2:4] # hexa convertion
V_previous_error_hexa=str(hex(int(V_previous_error)))[2:4] # hexa convertion
V_previous_error_state=get_device_status(str(dummy_idx['boiler_error_log']))[0:2]
V_previous_problem_state=get_device_status(str(dummy_idx['problem']))
if V_error=="000":
if log_Info: print " -no internal error : all it is OK"+" (previous code="+V_previous_error_hexa+")"
#if V_previous_error_state!="OK": # I update boiler_error_log alert only if state is modified
# 25/07/2020: removed to get the boiler status updated in domoticz
svalue='OK (previous='+V_previous_error_hexa+')'
update_device_status(str(dummy_idx['boiler_error_log']),1, svalue)
if V_previous_problem_state=="On": # I update problem switch only if state is modified
if log_Info: print " -state of boiler error status changed (no problem): I update the Domotics boiler problem switch"
update_device_switch(str(dummy_idx['problem']), 'Off')
else:
if log_Info: print " -there is an internal error : code="+V_error_hexa+" ( previous ="+V_previous_error_hexa+")"
if V_previous_error_state!=V_error_hexa: # I update boiler_error_log alert only if state is modified
svalue=V_error_hexa+' error (previous='+V_previous_error_hexa+')'
update_device_status(str(dummy_idx['boiler_error_log']),4, svalue)
if V_previous_problem_state=="Off": # I update problem switch only if state is modified
if log_Info: print " -state of boiler error status changed (problem): I update the Domotics boiler problem switch"
update_device_switch(str(dummy_idx['problem']), 'On')
#----------------------------------------## Command ##---------------------------------------#
if nb_arg==2:
if check_set_command(sys.argv[1]):
if log_Info: print "set "+sys.argv[1]+" "+sys.argv[2]
tn=viTalk_connect()
viTalk_write(sys.argv[1],sys.argv[2])
tn.close()
if log_Info:
endTimer = timer()
print "End / elapsed: " +str(endTimer - startTimer)
err_text='ViTalk OK'
print err_text
update_alert('vitalk_error_log', err_text, 1)
lire le post mentionné en début de post pour voir les widgets à créer et les paramètres à postionner
