kuhinja battery change
[vaillant-thermostat] / temp3.sh
index 319af0a..5673c1a 100755 (executable)
--- a/temp3.sh
+++ b/temp3.sh
@@ -24,36 +24,83 @@ influx_mqtt() {
 
 #      echo "# $topic [$rids] -> $file"
        cat <<__SHELL__ >> /dev/shm/curl
-curl -G 'http://10.60.0.89:8086/query' --data-urlencode "db=telegraf" --data-urlencode "epoch=s" --data-urlencode "q=SELECT \"value\" FROM \"mqtt_stat\" WHERE time > now() - $INTERVAL AND \"topic\"='$topic' " | sed -e 's/^.*"values":\[\[//' -e 's/\],\[/\n/g' -e 's/,/ /g' -e 's/]].*$//' > /dev/shm/data.$file
+curl -G 'http://10.60.0.92:8086/query' --data-urlencode "db=telegraf" --data-urlencode "epoch=s" --data-urlencode "q=SELECT \"value\" FROM \"mqtt_stat\" WHERE time > now() - $INTERVAL AND \"topic\"='$topic' " | sed -e 's/^.*"values":\[\[//' -e 's/\],\[/\n/g' -e 's/,/ /g' -e 's/]].*$//' > /dev/shm/data.$file
 __SHELL__
 }
 
 influx_rtl() {
        file=$1
        shift;
-       rids=`echo $* | sed -e 's/\([0-9][0-9]*\)/ or "id" = '"'"'\1'"'"'/g' -e 's/^ or/ AND /'`
+       rids=`echo $* | sed -e 's/\([0-9][0-9]*\)/ or id = '"'"'\1'"'"'/g' -e 's/^ or//'`
 
 #      echo "# $topic [$rids] -> $file"
        cat <<__SHELL__ >> /dev/shm/curl
-curl -G 'http://10.60.0.89:8086/query' --data-urlencode "db=telegraf" --data-urlencode "epoch=s" --data-urlencode "q=SELECT \"temperature_C\",\"humidity\" FROM \"mqtt_rtl_433\" WHERE time > now() - $INTERVAL and model="Prologue-TH" $rids" | sed -e 's/^.*"values":\[\[//' -e 's/\],\[/\n/g' -e 's/,/ /g' -e 's/]].*$//' > /dev/shm/data.$file
+curl -G 'http://10.60.0.92:8086/query' --data-urlencode "db=telegraf" --data-urlencode "epoch=s" --data-urlencode "q=SELECT \"temperature_C\",\"humidity\" FROM \"mqtt_rtl_433\" WHERE time > now() - $INTERVAL and model='Prologue-TH' AND ( $rids )" | sed -e 's/^.*"values":\[\[//' -e 's/\],\[/\n/g' -e 's/,/ /g' -e 's/]].*$//' > /dev/shm/data.$file
 __SHELL__
 }
 
+influx_tele() {
+       topic=$1
+       t_col=$2
+       h_col=$3
+       file=$4
+
+       cat <<__SHELL__ >> /dev/shm/curl
+curl -G 'http://10.60.0.92:8086/query' --data-urlencode "db=telegraf" --data-urlencode "epoch=s" --data-urlencode "q=SELECT \"$t_col\",\"$h_col\" FROM \"mqtt_tele_sensor\" WHERE time > now() - $INTERVAL and topic='$topic'" | sed -e 's/^.*"values":\[\[//' -e 's/\],\[/\n/g' -e 's/,/ /g' -e 's/]].*$//' > /dev/shm/data.$file
+__SHELL__
+}
+
+curl -G 'http://10.60.0.92:8086/query' --data-urlencode "db=rtl_433" --data-urlencode "q=SELECT time,id,temperature_C,humidity FROM \"Prologue-TH\" WHERE time > now() - $INTERVAL" -H "Accept: application/csv" --data-urlencode "epoch=s" \
+       | tee /dev/shm/rtl_433.th \
+       | awk -F, '{print $3" "$5" "$6 > "/dev/shm/id."$4 }'
+
+psql_subvision() {
+       to=$1
+       echo "select extract(epoch from time), temperature, humidity from s_1 where time > now() - interval '$INTERVAL' order by time" | \
+               ssh subvision psql -t -A eg5120 | sed 's/|/ /g' > /dev/shm/data.$to
+}
+
+
+rename_ids() {
+       to=$1
+       shift
+       while [ ! -z "$1" ] ; do
+               if [ -e /dev/shm/id.$1 ] ; then
+                       cat /dev/shm/id.$1 > /dev/shm/data.$to
+                       rm  /dev/shm/id.$1
+               else
+                       rm /dev/shm/data.$to
+               fi
+               shift
+       done
+}
+
+rename_ids     'vani-t-h' 156 # sunce
+rename_ids     'kutija-t-h' 138 # hlad
+#rename_ids    'kupaona-t-h' 78 15
+psql_subvision 'kupaona-t-h'
+rename_ids     'kuhinja-t-h' 144
+rename_ids     'soba-t-h' 251
+rename_ids     'hodnik-t-h' 234
+
+
 influx_mqtt    'stat/boiler/DS18B20/temperature'       'DS18B20-t'
 influx_mqtt    'stat/boiler/DHT22/temperature'         'DHT22-t'
 influx_mqtt    'stat/boiler/DHT22/humidity'            'DHT22-h'
 
+#influx_tele   'tele/ir/SENSOR' 'AM2301_Temperature' 'AM2301_Humidity' 'ir-dht22-t-h'
+#influx_tele   'tele/dht11-ir-hdmi/SENSOR' 'DHT11_Temperature' 'DHT11_Humidity' 'stol-dht11-t-h'
+
 influx_mqtt    'stat/boiler/d'                         'boiler-d'
 
-influx_rtl     'vani-t-h' 40 0
-influx_rtl     'kutija-t-h' 95 90
-influx_rtl     'kupaona-t-h' 125 148
-influx_rtl     'kuhinja-t-h' 175 239
-influx_rtl     'soba-t-h' 59
+#influx_rtl    'vani-t-h' 0 165 234
+#influx_rtl    'kutija-t-h' 104 228 241 # hlad
+#influx_rtl    'kupaona-t-h' 114 98
+#influx_rtl    'kuhinja-t-h' 199 27
+#influx_rtl    'soba-t-h' 59 252
 
 cat /dev/shm/curl | parallel
 
-
 GRAY=`echo $QUERY_STRING | grep -i gray | wc -l`
 
 tz_secs=`date +%:z | cut -d: -f1 | sed -e 's/^+//' -e 's/$/ * 3600/' | bc`