comme j'ai eu quelques problèmes de connexion à viTalk que j'ai eu du mal à diagnostiquer, j'ai fait une évolution du script pour remonter les états de cette connexion dans domoticz.
J'ai aussi noté que quand cela ne fonctionne pas, l'interface avec viTalk est "coincée" et qu'un lancement par cron peut empiler les scripts, d'autant plus que pour avoir un bon calcul de la consommation, il faut lancer le script souvent.
J'ai donc fait un lanceur en shell pour vérifier cela.
Le python avec des paramètres ajoutés permettant de mettre à jour la conso seulement ou les autres données ou les deux:
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.32 - Hestia - 09/09/2020
# update vitalk status at the end if ok instead of the begining
import telnetlib
import sys
import os
import time
import datetime
import requests
from requests.auth import HTTPBasicAuth
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='xxxxxxx' #IP or DNS
domoticz_port='8080'
user=''
password=''
#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
# 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,auth=HTTPBasicAuth(user,password))
####
########################################################################
###### 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
####
#######################################################################
###### _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_erviTalkror_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),auth=HTTPBasicAuth(user,password))
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,auth=HTTPBasicAuth(user,password))
####
########################################################################
###### 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),auth=HTTPBasicAuth(user,password))
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,auth=HTTPBasicAuth(user,password))
###
########################################################################
###### 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),auth=HTTPBasicAuth(user,password))
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=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))
# 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
if log_Info:
print "Runtime;VPower;P0;Wh;GazL;Gaz0;MobAvg"
print 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)