Domoticz

Code: Select all

import urllib
domDevice=25     # your device number
...
dataValue =      # find the bit of script that has a meter reading
...
httpresponse = urllib.urlopen("http://127.0.0.1:8080/json.htm?type=command&param=udevice&idx=" + str(domDevice) + "&nvalue=0&svalue=" + dataValue )

Code: Select all

sudo apt-get update
sudo apt-get install python-serial
sudo apt-get install python-requests

Code: Select all

#!/usr/bin/env python
#
#	Script to parse Current Cost data to Domoticz
#   
#		(C)reated 2014 by Rtm-soft
#

import serial
import os
import requests

#Constants

COMPORT = "/dev/ttyUSB22"
COMPORT_BAUD = 57600
DOMOTICZ_URL = "http://192.168.9.31:8080"	#http://<username:password@>domoticz-ip<:port>
TEMP_IDX = "94"					#Domoticz index Dummy THR128/138, THC138
METER_IDX = "53"				#Domoticz index Dummy Energy meter CM119/CM160

#Variables

kwh	= "0"		#Last Months total
#watts	= "0"		#Current watts
#tmpr	= "0"		#Current temperature

# connect to the CurrentCost meter

ser = None
try:
    ser = serial.Serial(port=COMPORT, baudrate=COMPORT_BAUD, timeout=30)
except serial.SerialException, msg:
    print("Failed to connect to CurrentCost meter :: " + str(msg))
    exit(1)


print ("Connected to "+COMPORT+" at "+str(COMPORT_BAUD)+" Baud!")


while True:

	line = ser.readline()	# read a line of XML from the CurrentCost meter
	#print line
	if line.find("hist")==-1 : 		#No history packet, read temperature and current watts
		pos = line.find("tmpr") 	#Find current temperature
		if  pos !=-1 :
			tmpr = line[pos+5:pos+9]
			url= DOMOTICZ_URL+"/json.htm?type=command&param=udevice&idx="+TEMP_IDX+"&nvalue=0&svalue="+tmpr
			requests.get(url)
		pos = line.find("watts")	#Find current watts
		if  pos !=-1 :
			watts = line[pos+6:pos+11]
	else :
		pos = line.find("sensor>0<")		#Looking for last days total for sensor 0
		if  pos !=-1 :
			pos2 = line.find("d001",pos)	#Find lastsday total only for sensor 0
			if pos2 !=-1 :
				tmpkwh = line[pos2+5:pos2+11] #Use temp value so that it can be modified
				kwh = tmpkwh.replace(".","")	#Remove dot out of string. Domoticz wants Wh
	url= DOMOTICZ_URL+"/json.htm?type=command&param=udevice&idx="+METER_IDX+"&nvalue=0&svalue="+watts+";"+kwh
	#print url
	requests.get(url) 
exit(0)

Code: Select all

pi@raspberrypi ~/scripts $ python envir.py
Traceback (most recent call last):
  File "envir.py", line 10, in <module>
    import requests
ImportError: No module named requests

Code: Select all

root@raspberrypi:/scripts# python domo_measure.py
Connected to /dev/ttyUSB0 at 57600 Baud!

Code: Select all

^CTraceback (most recent call last):
  File "domo_measure.py", line 41, in <module>
    line = ser.readline()   # read a line of XML from the CurrentCost meter
  File "/usr/lib/python2.7/dist-packages/serial/serialposix.py", line 442, in read
    ready,_,_ = select.select([self.fd],[],[], self._timeout)
KeyboardInterrupt

Code: Select all

{"0":{"sensor":{"x":"","sensor_id":"0","sensor_title":"optisense","sensor_clamp":"0","position_id":"2","position_time":"2013-10-14 18:36:12","position_description":"optisense","position_sensor":"0","measure_history":"365","measure_currency":"Euro","measure_sensor":"0","measure_range":"","measure_timeframe":"0","measure_timezone":"GMT0","measure_timezone_diff":"2","measure_type":"0","measure_pvoutput_id":"0","measure_pvoutput_api":"","positions":{"2":{"position":"2","time":"2013-10-14 18:36:12","description":"optisense"}}},"tmpr":"20.8","watt":"104","daily":"9.858 Kwh
0","hourly":"0.432 Kwh
0","weekly":"72.135 Kwh
0","monthly":"368.029 Kwh
0"},"1":{"sensor":{"x":"","sensor_id":"1","sensor_title":"stroomtangen","sensor_clamp":"0","position_id":"4","position_time":"2013-10-14 19:39:49","position_description":"stroomtangen","position_sensor":"1","measure_history":"365","measure_currency":"Euro","measure_sensor":"1","measure_range":"","measure_timeframe":"0","measure_timezone":"GMT0","measure_timezone_diff":"2","measure_type":"0","measure_pvoutput_id":"0","measure_pvoutput_api":"","positions":{"4":{"position":"4","time":"2013-10-14 19:39:49","description":"stroomtangen"}}},"tmpr":"20.8","watt":"455","daily":"12.854 Kwh
0","hourly":"0.599 Kwh
0","weekly":"87.251 Kwh
0","monthly":"403.289 Kwh
0"},"11":{"sensor":{"x":"","sensor_id":"11","sensor_title":"fase1","sensor_clamp":"0","position_id":"3","position_time":"2013-10-14 19:38:40","position_description":"fase1","position_sensor":"11","measure_history":"365","measure_currency":"Euro","measure_sensor":"11","measure_range":"","measure_timeframe":"0","measure_timezone":"GMT0","measure_timezone_diff":"2","measure_type":"0","measure_pvoutput_id":"0","measure_pvoutput_api":"","positions":{"3":{"position":"3","time":"2013-10-14 19:38:40","description":"fase1"}}},"tmpr":"20.8","watt":"174","daily":"3.957 Kwh
0","hourly":"0.176 Kwh
0","weekly":"27.799 Kwh
0","monthly":"137.913 Kwh
0"},"21":{"sensor":{"x":"","sensor_id":"21","sensor_title":"fase2","sensor_clamp":"0","position_id":"6","position_time":"2013-10-14 19:41:13","position_description":"fase2","position_sensor":"21","measure_history":"365","measure_currency":"Euro","measure_sensor":"21","measure_range":"","measure_timeframe":"0","measure_timezone":"GMT0","measure_timezone_diff":"2","measure_type":"0","measure_pvoutput_id":"0","measure_pvoutput_api":"","positions":{"6":{"position":"6","time":"2013-10-14 19:41:13","description":"fase2"}}},"tmpr":"20.8","watt":"75","daily":"2.333 Kwh
0","hourly":"0.17 Kwh
0","weekly":"16.929 Kwh
0","monthly":"74.725 Kwh
0"},"31":{"sensor":{"x":"","sensor_id":"31","sensor_title":"fase3","sensor_clamp":"0","position_id":"7","position_time":"2013-10-14 19:41:42","position_description":"fase3","position_sensor":"31","measure_history":"365","measure_currency":"Euro","measure_sensor":"31","measure_range":"","measure_timeframe":"0","measure_timezone":"GMT0","measure_timezone_diff":"2","measure_type":"0","measure_pvoutput_id":"0","measure_pvoutput_api":"","positions":{"7":{"position":"7","time":"2013-10-14 19:41:42","description":"fase3"}}},"tmpr":"20.8","watt":"206","daily":"6.604 Kwh
0","hourly":"0.264 Kwh
0","weekly":"42.87 Kwh
0","monthly":"192.297 Kwh
0"}}

Code: Select all

#!/usr/bin/env python
#
#   Script to parse Current Cost data to Domoticz
#   
#      (C)reated 2014 by Rtm-soft
#

import serial
import os
import requests

#Constants

COMPORT = "COM4"
COMPORT_BAUD = 9600
DOMOTICZ_URL = "http://192.168.1.95:8080"   #http://<username:password@>domoticz-ip<:port>
TEMP_IDX = "37"               #Domoticz index Dummy THR128/138, THC138
METER_IDX = "36"            #Domoticz index Dummy Energy meter CM119/CM160

#Variables

kwh2   = "0"      #Yesterdays total
#watts   = "0"      #Current watts
#tmpr   = "0"      #Current temperature

# connect to the CurrentCost meter

ser = None
try:
    ser = serial.Serial(port=COMPORT, baudrate=COMPORT_BAUD, timeout=30)
except serial.SerialException:#, msg:
    print("Failed to connect to CurrentCost meter :: " + str(msg))
    exit(1)


print ("Connected to "+COMPORT+" at "+str(COMPORT_BAUD)+" Baud!")
print (ser.name)

print ("Trying to read lines now....")

while True:
   line = str(ser.readline())   # read a line of XML from the CurrentCost meter
   #print (line) # Uncomment out this row if you want to see the raw XML
   if line.find("hist")==-1 :       #No history packet, read current watts
      print ("Reading a normal line....")
      pos = line.find("<ch1><watts>")   #Find current watts for Channel 1
      if  pos !=-1 :
         watts = line[pos+12:pos+17]
         url= DOMOTICZ_URL+"/json.htm?type=command&param=udevice&idx="+METER_IDX+"&nvalue=0&svalue="+watts+";"+kwh2
         print (str(url))
         requests.get(url)
   else : # history packet, read temperature, current watts and kWh
      print ("Reading a history line....")
      pos = line.find("tmpr")    #Find current temperature
      if  pos !=-1 :
         tmpr = line[pos+5:pos+9]
         url= DOMOTICZ_URL+"/json.htm?type=command&param=udevice&idx="+TEMP_IDX+"&nvalue=0&svalue="+tmpr
         print (str(url))
         requests.get(url)
      pos = line.find("<ch1><watts>")   #Find current watts
      if  pos !=-1 :
         watts = str(int(float(line[pos+12:pos+17])))
         pos = line.find("<days><d01>")      #Looking for last days total kwh
         if  pos !=-1 :
            kwh = line[pos+11:pos+15]
            kwh2 = str(int(float(kwh)) * 1000) # Domoticz seems to divide the value by 1000 so we'll multiply it by 1000
         url= DOMOTICZ_URL+"/json.htm?type=command&param=udevice&idx="+METER_IDX+"&nvalue=0&svalue="+watts+";"+kwh2
         print (str(url))
         requests.get(url) 
exit(0)

Code: Select all

http://192.168.2.27:8080/json.htm?type=command&param=udevice&idx=7&nvalue=0&svalue=00498;0
Reading a normal line....
http://192.168.2.27:8080/json.htm?type=command&param=udevice&idx=7&nvalue=0&svalue=00127;0
Reading a normal line....
http://192.168.2.27:8080/json.htm?type=command&param=udevice&idx=7&nvalue=0&svalue=00498;0
Reading a normal line....
http://192.168.2.27:8080/json.htm?type=command&param=udevice&idx=7&nvalue=0&svalue=00137;0
Reading a normal line....
http://192.168.2.27:8080/json.htm?type=command&param=udevice&idx=7&nvalue=0&svalue=00498;0
Reading a normal line....
http://192.168.2.27:8080/json.htm?type=command&param=udevice&idx=7&nvalue=0&svalue=00138;0
Reading a normal line....
http://192.168.2.27:8080/json.htm?type=command&param=udevice&idx=7&nvalue=0&svalue=00498;0
Reading a normal line....
http://192.168.2.27:8080/json.htm?type=command&param=udevice&idx=7&nvalue=0&svalue=00128;0
Reading a normal line....
Reading a normal line....

Code: Select all

#!/usr/bin/perl -w

# Reads data from a Current Cost device via serial port.

use strict;
use Device::SerialPort qw( :PARAM :STAT 0.07 );

my $PORT = "/dev/electric";
my $dom_server = "192.168.2.12";
my $dom_port = "8080";
my $idx = 607;

my $ob = Device::SerialPort->new($PORT);
$ob->baudrate(57600);
#$ob->parity("none");
#$ob->databits(8);
#$ob->stopbits(1);
$ob->write_settings;

my $prev_counter = 0;
my $new_counter = 0;
my $p1 = 0;
my $p2 = 0;
my $p3 = 0;
my $etotal = 0;
my $temp = 0;

 my $STALL_DEFAULT=35; # how many seconds to wait for new input

 my $timeout=$STALL_DEFAULT;

 $ob->read_char_time(0);     # don't wait for each character
 $ob->read_const_time(1000); # 1 second per unfulfilled "read" call

 my $chars=0;
 my $buffer="";
 while ($timeout>0) {
        my ($count,$saw)=$ob->read(10); # will read _up to_ 255 chars
        if ($count > 0) {
                $chars+=$count;
                $buffer.=$saw;
                print $saw;

                if ($buffer =~ m!<tmpr> *([\-\d.]+)</tmpr>.*<ch1><watts>0*(\d+)</watts></ch1><ch2><watts>0*(\d+)</watts></ch2><ch3><watts>0*(\d+)</watts></ch3>!) {
        $temp = $1;
        $p1 = $2;
        $p2 = $3;
        $p3 = $4;
        $etotal = $p1 + $p2 + $p3;
        last;
        }
        }

else {
                $timeout--;
        }
 }

 if ($timeout==0) {
        print $buffer ."\n";
        die "Waited $STALL_DEFAULT seconds and never saw what I wanted\n";
 }

open (my $cfh, '<', "/home/a-jones/electric_counter.txt");
while (my $cline = <$cfh>) {
chomp $cline;
$prev_counter = $cline;
}
close $cfh;

print "Instant Reading: \n";
print "Phase1: $p1, Phase2: $p2, Phase3: $p3\n";
print "Total: $etotal\n";
print "\nPrevious Counter: $prev_counter KWh\n";
my $kwh = ($etotal / 60);
print "KWh: $kwh\n";
$new_counter = $prev_counter + $kwh;
print "New Counter: $new_counter\n";
print "----------------------\n";

open (my $efh, '>', "/home/a-jones/electric.txt");
print $efh "$p1,$p2,$p3,$etotal,$temp";
close $efh;

open (my $ncfh, '>', "/home/a-jones/electric_counter.txt");
print $ncfh "$new_counter";
close $ncfh;

my $dom_url = "http://$dom_server:$dom_port/json.htm?type=command&param=udevice&idx=$idx&nvalue=0&svalue=$etotal;$new_counter";

use LWP::Simple;
my $content = get $dom_url;
die "Couldn't get $dom_url" unless defined $content;

print "Return from Domoticz: \n";
print "$content";