Verbraucher SDM 630

SDM630 als Verbraucher Zähler fertig gestellt
webermax · Mar 12, 2020 · 88aadbe · 88aadbe
1 parent abd66b4
commit 88aadbe
Show file tree

Hide file tree

Showing 7 changed files with 438 additions and 4 deletions.
diff --git a/.gitignore b/.gitignore
@@ -2,3 +2,4 @@ web/ladelog
 *.csv
 *.log
 ramdisk/
+.DS_Store
diff --git a/hook.sh b/hook.sh
@@ -157,9 +157,9 @@ if (( verbraucher1_aktiv == "1")); then
 	fi
 	if [[ $verbraucher1_typ == "sdm630" ]]; then
 		if [[ $verbraucher1_source == *"dev"* ]]; then
-			sudo python modules/verbraucher/mpm3pmlocal.py 1 $verbraucher1_source $verbraucher1_id &
+			sudo python modules/verbraucher/sdm630local.py 1 $verbraucher1_source $verbraucher1_id &
 		else
-			sudo python modules/verbraucher/mpm3pmremote.py 1 $verbraucher1_source $verbraucher1_id &
+			sudo python modules/verbraucher/sdm630remote.py 1 $verbraucher1_source $verbraucher1_id &
 		fi
 	fi
 
@@ -202,9 +202,9 @@ if (( verbraucher2_aktiv == "1")); then
 	fi
 	if [[ $verbraucher2_typ == "sdm630" ]]; then
 		if [[ $verbraucher2_source == *"dev"* ]]; then
-			sudo python modules/verbraucher/mpm3pmlocal.py 2 $verbraucher2_source $verbraucher2_id &
+			sudo python modules/verbraucher/sdm630local.py 2 $verbraucher2_source $verbraucher2_id &
 		else
-			sudo python modules/verbraucher/mpm3pmremote.py 2 $verbraucher2_source $verbraucher2_id &
+			sudo python modules/verbraucher/sdm630remote.py 2 $verbraucher2_source $verbraucher2_id &
 		fi
 	fi
 

diff --git a/modules/goesdm630lp1/main.sh b/modules/goesdm630lp1/main.sh
@@ -0,0 +1,205 @@
+#!/bin/bash
+. /var/www/html/openWB/openwb.conf
+re='^-?[0-9]+$'
+rekwh='^[-+]?[0-9]+\.?[0-9]*$'
+
+output=$(curl --connect-timeout $goetimeoutlp1 -s http://$goeiplp1/status)
+if [[ $? == "0" ]] ; then
+	watt=$(echo $output | jq -r '.nrg[11]')
+	watt=$(echo "scale=0;$watt * 10 /1" |bc)
+	if [[ $watt =~ $re ]] ; then
+		echo $watt > /dev/null
+	fi
+	lla1=$(echo $output | jq -r '.nrg[4]')
+	lla1=$(echo "scale=0;$lla1 / 10" |bc)
+	if [[ $lla1 =~ $re ]] ; then
+		echo $lla1 > /dev/null
+	fi
+	lla2=$(echo $output | jq -r '.nrg[5]')
+	lla2=$(echo "scale=0;$lla2 / 10" |bc)
+	if [[ $lla2 =~ $re ]] ; then
+		echo $lla2 > /dev/null
+	fi
+	lla3=$(echo $output | jq -r '.nrg[6]')
+	lla3=$(echo "scale=0;$lla3 / 10" |bc)
+	if [[ $lla3 =~ $re ]] ; then
+		echo $lla3 > /dev/null
+	fi
+	llv1=$(echo $output | jq -r '.nrg[0]')
+	if [[ $llv1 =~ $re ]] ; then
+		echo $llv1 > /dev/null
+	fi
+	llv2=$(echo $output | jq -r '.nrg[1]')
+	if [[ $llv2 =~ $re ]] ; then
+		echo $llv2 > /dev/null
+	fi
+	llv3=$(echo $output | jq -r '.nrg[2]')
+	if [[ $llv3 =~ $re ]] ; then
+		echo $llv3 > /dev/null
+	fi
+
+	llkwh=$(echo $output | jq -r '.eto')
+	llkwh=$(echo "scale=3;$llkwh / 10" |bc)
+	if [[ $llkwh =~ $rekwh ]] ; then
+		echo $llkwh > /dev/null
+	fi
+	rfid=$(echo $output | jq -r '.uby')
+	oldrfid=$(</var/www/html/openWB/ramdisk/tmpgoelp1rfid)
+	if [[ $rfid != $oldrfid ]] ; then
+		echo $rfid > /var/www/html/openWB/ramdisk/readtag
+		echo $rfid > /var/www/html/openWB/ramdisk/tmpgoelp1rfid
+	fi
+#car status 1 Ladestation bereit, kein Auto
+#car status 2 Auto lädt
+#car status 3 Warte auf Fahrzeug
+#car status 4 Ladung beendet, Fahrzeug verbunden
+    car=$(echo $output | jq -r '.car')
+    if [[ $car == "1" ]] ; then
+      echo 0 > /var/www/html/openWB/ramdisk/plugstat
+    else
+      echo 1 > /var/www/html/openWB/ramdisk/plugstat
+    fi
+    if [[ $car == "2" ]] ; then
+      echo 1 > /var/www/html/openWB/ramdisk/chargestat
+    else
+	      echo 0 > /var/www/html/openWB/ramdisk/chargestat
+     fi
+fi
+
+#sdm630 abrufen
+#if [[ $sdm630modbusllsource = *virtual* ]]
+#then
+#	if ps ax |grep -v grep |grep "socat pty,link=$sdm630modbusllsource,raw tcp:$goeipsdm630lp1:502" > /dev/null
+#	then
+#		echo "test" > /dev/null
+#	else
+#		sudo socat pty,link=$sdm630modbusllsource,raw tcp:$goeipsdm630lp1:502 &
+#	fi
+#else
+#	echo "echo" > /dev/null
+#fi
+if ping -c 1 $goeipsdm630lp1 > /dev/null
+then
+    n=0
+    output=$(sudo python /var/www/html/openWB/modules/goesdm630lp1/readsdm.py $goeipsdm630lp1 $goeidsdm630lp1)
+    while read -r line; do
+        if (( $n == 0 )); then
+            lla1=$(echo "$line" |  cut -c2- )
+            lla1=${lla1%???}
+    #		LANG=C printf "%.3f\n" $lla1 > /var/www/html/openWB/ramdisk/lla1
+    #		echo "$line" |  cut -c2- |sed 's/\..*$//' > /var/www/html/openWB/ramdisk/lla1
+            echo "scale=3; $lla1/1" | bc -l > /var/www/html/openWB/ramdisk/lla1
+
+        fi
+        if (( $n == 1 )); then
+            lla2=$(echo "$line" |  cut -c2- )
+            lla2=${lla2%???}
+    #		LANG=C printf "%.3f\n" $lla2 > /var/www/html/openWB/ramdisk/lla2
+    #		echo "$line" |  cut -c2- |sed 's/\..*$//' > /var/www/html/openWB/ramdisk/lla2
+            echo "scale=3; $lla2/1" | bc -l > /var/www/html/openWB/ramdisk/lla2
+
+        fi
+        if (( $n == 2 )); then
+            lla3=$(echo "$line" |  cut -c2- )
+            lla3=${lla3%???}
+            echo "scale=3; $lla3/1" | bc -l > /var/www/html/openWB/ramdisk/lla3
+
+    #		LANG=C printf "%.3f\n" $lla3 > /var/www/html/openWB/ramdisk/lla3
+    #		echo "$line" |  cut -c2- |sed 's/\..*$//' > /var/www/html/openWB/ramdisk/lla3
+
+        fi
+    if (( $n == 3 )); then
+        wl1=$(echo "$line" |  cut -c2- |sed 's/\..*$//')
+    fi
+    if (( $n == 4 )); then
+        llkwh=$(echo "$line" |  cut -c2- )
+        llkwh=${llkwh%???}
+        rekwh='^[-+]?[0-9]+\.?[0-9]*$'
+        if [[ $llkwh =~ $rekwh ]]; then
+            #LANG=C printf "%.3f\n" $llkwh > /var/www/html/openWB/ramdisk/llkwh
+            echo "scale=3; $llkwh/1" | bc -l > /var/www/html/openWB/ramdisk/llkwh
+
+        fi
+    fi
+    if (( $n == 5 )); then
+        wl2=$(echo "$line" |  cut -c2- |sed 's/\..*$//')
+    fi
+    if (( $n == 6 )); then
+        wl3=$(echo "$line" |  cut -c2- |sed 's/\..*$//')
+    fi
+    if (( $n == 7 )); then
+    llv1=$(echo "$line" |  cut -c2- )
+    llv1=${llv1%???}
+    echo "scale=1; $llv1/1" | bc -l > /var/www/html/openWB/ramdisk/llv1
+    #LANG=C printf "%.1f\n" $llv1 > /var/www/html/openWB/ramdisk/llv1
+    #		echo "$line" |  cut -c2- |sed 's/\..*$//' > /var/www/html/openWB/ramdisk/llv1
+
+    fi
+    if (( $n == 8 )); then
+    llv2=$(echo "$line" |  cut -c2- )
+    llv2=${llv2%???}
+    echo "scale=1; $llv2/1" | bc -l > /var/www/html/openWB/ramdisk/llv2
+    #LANG=C printf "%.1f\n" $llv2 > /var/www/html/openWB/ramdisk/llv2
+    #echo "$line" |  cut -c2- |sed 's/\..*$//' > /var/www/html/openWB/ramdisk/llv2
+    fi
+    if (( $n == 9 )); then
+    llv3=$(echo "$line" |  cut -c2- )
+    llv3=${llv3%???}
+    echo "scale=1; $llv3/1" | bc -l > /var/www/html/openWB/ramdisk/llv3
+    #LANG=C printf "%.1f\n" $llv3 > /var/www/html/openWB/ramdisk/llv3
+    #		echo "$line" |  cut -c2- |sed 's/\..*$//' > /var/www/html/openWB/ramdisk/llv3
+    fi
+    if (( $n == 10 )); then
+    #echo "$line" |  cut -c2- |sed 's/\..*$//' > /var/www/html/openWB/ramdisk/llaltnv
+    #llaltnv=$(echo "$line" |  cut -c2- )
+    #llaltnv=${llaltnv%??}
+    #printf "%.1f\n" $llaltnv > /var/www/html/openWB/ramdisk/llaltnv
+            echo "$line" |  cut -c2- |sed 's/\..*$//' > /var/www/html/openWB/ramdisk/llaltnv
+    fi
+    if (( $n == 11 )); then
+    #	llhz=$(echo "$line" |  cut -c2- )
+    #	llhz=${llhz%??} 
+    #       printf "%.1f\n" $llhz > /var/www/html/openWB/ramdisk/llhz
+            echo "$line" |  cut -c2- |sed 's/\..*$//' > /var/www/html/openWB/ramdisk/llhz
+    echo "$line" |  cut -c2- |sed 's/\..*$//' > /var/www/html/openWB/ramdisk/evuhz
+
+    fi
+    if (( $n == 12 )); then
+    llpf1=$(echo "$line" |  cut -c2- )
+    llpf1=${llpf1%??}
+    echo "scale=3; $llpf1/1" | bc -l > /var/www/html/openWB/ramdisk/llpf1
+    #LANG=C printf "%.3f\n" $llpf1 > /var/www/html/openWB/ramdisk/llpf1
+
+    fi
+    if (( $n == 13 )); then
+    llpf2=$(echo "$line" |  cut -c2- )
+    llpf2=${llpf2%??}
+    echo "scale=3; $llpf2/1" | bc -l > /var/www/html/openWB/ramdisk/llpf2
+    #LANG=C printf "%.3f\n" $llpf2 > /var/www/html/openWB/ramdisk/llpf2
+    fi
+    if (( $n == 14 )); then
+    llpf3=$(echo "$line" |  cut -c2- )
+    llpf3=${llpf3%??}
+    echo "scale=3; $llpf3/1" | bc -l > /var/www/html/openWB/ramdisk/llpf3
+    #LANG=C printf "%.3f\n" $llpf3 > /var/www/html/openWB/ramdisk/llpf3
+    fi
+
+
+        n=$((n + 1))
+        done <<< "$output"
+
+
+
+    re='^-?[0-9]+$'
+    if [[ $wl1 =~ $re ]] && [[ $wl2 =~ $re ]] && [[ $wl3 =~ $re ]]; then
+        llaktuell=`echo "($wl1+$wl2+$wl3)" |bc`
+        #Grundrauschen des GOE-Chargers bei nicht laden nicht anzeigen.
+        if [ $llaktuell == 6 ]; then
+        echo 0 >/var/www/html/openWB/ramdisk/llaktuell
+        elif [ $llaktuell == 5 ]; then
+        echo 0 > /var/www/html/openWB/ramdisk/llaktuell
+        else 
+        echo $llaktuell > /var/www/html/openWB/ramdisk/llaktuell
+        fi
+    fi
+fi
diff --git a/modules/goesdm630lp1/readsdm.py b/modules/goesdm630lp1/readsdm.py
@@ -0,0 +1,49 @@
+#!/usr/bin/python
+import sys
+import os
+import time
+import getopt
+import socket
+import ConfigParser
+import struct
+import binascii
+seradd = str(sys.argv[1])
+from pymodbus.client.sync import ModbusTcpClient
+client = ModbusTcpClient(seradd,port=502)
+
+#rq = client.read_holding_registers(0,8,unit=5)
+#print(rq.registers)
+sdmid = int(sys.argv[2])
+
+resp = client.read_input_registers(0x06,2, unit=sdmid)
+
+print(struct.unpack('>f',struct.pack('>HH',*resp.registers)))
+resp = client.read_input_registers(0x08,2, unit=sdmid)
+print(struct.unpack('>f',struct.pack('>HH',*resp.registers)))
+resp = client.read_input_registers(0x0A,2, unit=sdmid)
+print(struct.unpack('>f',struct.pack('>HH',*resp.registers)))
+
+resp = client.read_input_registers(0x0C,2, unit=sdmid)
+print(struct.unpack('>f',struct.pack('>HH',*resp.registers)))
+resp = client.read_input_registers(0x0156,2, unit=sdmid)
+print(struct.unpack('>f',struct.pack('>HH',*resp.registers)))
+resp = client.read_input_registers(0x0E,2, unit=sdmid)
+print(struct.unpack('>f',struct.pack('>HH',*resp.registers)))
+resp = client.read_input_registers(0x10,2, unit=sdmid)
+print(struct.unpack('>f',struct.pack('>HH',*resp.registers)))
+resp = client.read_input_registers(0x00,2, unit=sdmid)
+print(struct.unpack('>f',struct.pack('>HH',*resp.registers)))
+resp = client.read_input_registers(0x02,2, unit=sdmid)
+print(struct.unpack('>f',struct.pack('>HH',*resp.registers)))
+resp = client.read_input_registers(0x04,2, unit=sdmid)
+print(struct.unpack('>f',struct.pack('>HH',*resp.registers)))
+resp = client.read_input_registers(0x2A,2, unit=sdmid)
+print(struct.unpack('>f',struct.pack('>HH',*resp.registers)))
+resp = client.read_input_registers(0x46,2, unit=sdmid)
+print(struct.unpack('>f',struct.pack('>HH',*resp.registers)))
+resp = client.read_input_registers(0x1E,2, unit=sdmid)
+print(struct.unpack('>f',struct.pack('>HH',*resp.registers)))
+resp = client.read_input_registers(0x20,2, unit=sdmid)
+print(struct.unpack('>f',struct.pack('>HH',*resp.registers)))
+resp = client.read_input_registers(0x22,2, unit=sdmid)
+print(struct.unpack('>f',struct.pack('>HH',*resp.registers)))
diff --git a/modules/verbraucher/sdm630local.py b/modules/verbraucher/sdm630local.py
@@ -0,0 +1,89 @@
+#!/usr/bin/python
+import sys
+import os
+import time
+import getopt
+import socket
+import ConfigParser
+import struct
+import binascii
+#Args in var schreiben
+verbrauchernr = str(sys.argv[1])
+seradd = str(sys.argv[2])
+sdmid = int(sys.argv[3])
+
+from pymodbus.client.sync import ModbusSerialClient
+client = ModbusSerialClient(method = "rtu", port=seradd, baudrate=9600,
+                                stopbits=1, bytesize=8, timeout=1)
+
+#Phase 1 A
+resp = client.read_input_registers(0x06,2, unit=sdmid)
+al1 = struct.unpack('>f',struct.pack('>HH',*resp.registers))
+al1 = float("%.3f" % al1[0])
+al1string = "/var/www/html/openWB/ramdisk/verbraucher%s_a1" % (verbrauchernr)
+f = open(al1string, 'w')
+f.write(str(al1))
+f.close()
+
+#Phase 2 A
+resp = client.read_input_registers(0x08,2, unit=sdmid)
+al2 = struct.unpack('>f',struct.pack('>HH',*resp.registers))
+al2= float("%.3f" % al2[0])
+al1string = "/var/www/html/openWB/ramdisk/verbraucher%s_a2" % (verbrauchernr)
+f = open(al1string, 'w')
+f.write(str(al2))
+f.close()
+
+#Phase 3 A
+resp = client.read_input_registers(0x0A,2, unit=sdmid)
+al3 = struct.unpack('>f',struct.pack('>HH',*resp.registers))
+al3 = float("%.3f" % al3[0])
+al1string = "/var/www/html/openWB/ramdisk/verbraucher%s_a3" % (verbrauchernr)
+f = open(al1string, 'w')
+f.write(str(al3))
+f.close()
+
+#Phase 1 V
+resp = client.read_input_registers(0x00,2, unit=sdmid)
+av1 = struct.unpack('>f',struct.pack('>HH',*resp.registers))
+av1 = float("%.3f" % av1[0])
+av1string = "/var/www/html/openWB/ramdisk/verbraucher%s_v1" % (verbrauchernr)
+f = open(al1string, 'w')
+f.write(str(av1))
+f.close()
+
+#Phase 2 V
+resp = client.read_input_registers(0x02,2, unit=sdmid)
+av2 = struct.unpack('>f',struct.pack('>HH',*resp.registers))
+av2 = float("%.3f" % av2[0])
+al1string = "/var/www/html/openWB/ramdisk/verbraucher%s_v2" % (verbrauchernr)
+f = open(al1string, 'w')
+f.write(str(av1))
+f.close()
+
+#Phase 3 V
+resp = client.read_input_registers(0x04,2, unit=sdmid)
+av3 = struct.unpack('>f',struct.pack('>HH',*resp.registers))
+av3 = float("%.3f" % av3[0])
+al1string = "/var/www/html/openWB/ramdisk/verbraucher%s_v3" % (verbrauchernr)
+f = open(al1string, 'w')
+f.write(str(av3))
+f.close()
+#KWH Total
+resp = client.read_input_registers(0x0156,2, unit=sdmid)
+vwh = struct.unpack('>f',struct.pack('>HH',*resp.registers))
+vwh2 = float("%.3f" % vwh[0]) * int(1000)
+vwh3 = str(vwh2)
+vwhstring = "/var/www/html/openWB/ramdisk/verbraucher%s_wh" % (verbrauchernr)
+f = open(vwhstring, 'w')
+f.write(str(vwh3))
+f.close()
+
+#Aktueller Verbrauch
+resp = client.read_input_registers(0x0034,2, unit=sdmid)
+watt = struct.unpack('>f',struct.pack('>HH',*resp.registers))
+watt = int(watt[0])
+wattstring = "/var/www/html/openWB/ramdisk/verbraucher%s_watt" % (verbrauchernr)
+f = open(wattstring, 'w')
+f.write(str(watt))
+f.close()
-Original file line number
+Diff line change
@@ Expand Up / @@ -2,3 +2,4 @@ web/ladelog @@
     *.csv
     *.log
     ramdisk/
+    .DS_Store