openWB Forum

Code: Alles auswählen

echo "-$(/usr/local/bin/sbfspot.3/SBFspot -nocsv -nosql -finq -v | grep ETotal | sed 's/.*: *//' | sed 's/kW.*//')*1000" | bc | sed 's/\..*//' > /var/www/html/openWB/ramdisk/pvewh

echo "-$(/usr/local/bin/sbfspot.3/SBFspot -nocsv -nosql -finq -v | grep "Total Pac" | sed 's/.*: *//' | sed 's/kW.*//' )*1000" | bc | sed 's/\..*//' > /var/www/html/openWB/ramdisk/pvwatt

Code: Alles auswählen

# /usr/local/bin/sbfspot.3/SBFspot.Batt.cfg
IP_Address=192.168.2.106
Password=0000
Plantname=Batterie
OutputPath=/home/pi/smadata/%Y
Timezone=Europe/Berlin

Code: Alles auswählen

# /usr/local/bin/sbfspot.3/SBFspot.PV.cfg
IP_Address=192.168.2.103
Password=0000
Plantname=SMA-PV-WR
OutputPath=/home/pi/smadata/%Y
Timezone=Europe/Berlin

Code: Alles auswählen

#!/bin/bash
#set -e
# Datei: /var/www/html/openWB/sbfspot.sh, mittels chmod +x ausführbar machen!
# TODO: sbfspot Fehlermeldungen und leere Rückgabewerte abfangen, z.B. bei Netzwerkproblemen o.ä..
n=0;
while [ $n -lt 6 ] ; do
   /usr/local/bin/sbfspot.3/SBFspot -nocsv -nosql -finq -v -cfg/usr/local/bin/sbfspot.3/SBFspot.PV.cfg > /tmp/SMA
   echo "-1*$(grep ETotal /tmp/SMA | sed 's/.*: *//' | sed 's/kW.*//')*1000" | bc | sed 's/\..*//' > /var/www/html/openWB/ramdisk/pvewhsbf;
   echo "-1*$(grep "Total Pac" /tmp/SMA | sed 's/.*: *//' | sed 's/kW.*//')*1000" | bc | sed 's/\..*//' > /var/www/html/openWB/ramdisk/pvwattsbf;

   /usr/local/bin/sbfspot.3/SBFspot -nocsv -nosql -finq -v -cfg/usr/local/bin/sbfspot.3/SBFspot.Batt.cfg > /tmp/SMABatt
   echo "$(grep "Batt. Charging Status" /tmp/SMABatt | sed 's/.*: *//' | sed 's/%.*//')" > /var/www/html/openWB/ramdisk/speichersoc;
   echo "-1*$(grep "Total Pac" /tmp/SMABatt | sed 's/.*: *//' | sed 's/kW.*//')*1000" | bc | sed 's/\..*//' > /var/www/html/openWB/ramdisk/speicherleistung;

   rm /tmp/SMA /tmp/SMABatt;
   sleep 9; n=$(($n+1));
done

Code: Alles auswählen

* * * * * /var/www/html/openWB/sbfspot.sh

Code: Alles auswählen

sudo apt-get install python-twisted python-twisted-web

Code: Alles auswählen

# Das geht auch noch eleganter. ;)
/var/www/html/openWB/modules/wr_http/wr_speedwire.py > /var/www/html/tmp/wr_speedwire
wattwr=$(grep pvwatt /var/www/html/tmp/wr_speedwire | cut -d\  -f2)
ekwh=$(grep total /var/www/html/tmp/wr_speedwire | cut -d\  -f2)
rm /var/www/html/tmp/wr_speedwire

Code: Alles auswählen

#!/usr/bin/python

# sudo apt-get install python-twisted python-twisted-web

# Für openWB zusammengehackt von chmeyer aus den Quellen von:
# https://gist.github.com/hdo/6027504
# https://github.com/mhop/fhem-mirror/blob/master/fhem/FHEM/76_SMAInverter.pm
# Inspirationen aus SBFSpot.cpp
# https://github.com/SBFspot/SBFspot/blob/master/SBFspot/SBFspot.cpp

import struct
import sys
import time
import json
from struct import *
from twisted.web import server, resource
from twisted.internet.protocol import DatagramProtocol
from twisted.internet import reactor
from twisted.application.internet import MulticastServer


user_pw = '0000' # default is '0000'

code_login = 0xfffd040d
code_total_today = 0x54000201
code_spot_ac_power = 0x51000201

src_serial = 987193143 # = 37 5F D7 3A (intel format, little endian)
dst_serial = 4294967295 # = ff ff ff ff = anySerial, Abgeschaut von SMASpot...

comm_port = 9522
comm_dst = '192.168.2.103'


def get_encoded_pw(password):
    # user=0x88, install=0xBB
    encpw=[0x88,0x88,0x88,0x88,0x88,0x88,0x88,0x88,0x88,0x88,0x88,0x88]
    for index in range(min(len(encpw), len(password))):
        encpw[index] = encpw[index] + ord(password[index])
        
    ret = ""
    for ch in encpw:
        ret = ret + hex(ch).replace('0x','')
    return ret

cmd_login = '534d4100000402a000000001003a001060650ea0ffffffffffff00017800%s00010000000004800c04fdff07000000840300004c20cb5100000000%s00000000' % (struct.pack('<I', src_serial).encode('hex'), get_encoded_pw(user_pw))
cmd_logout = '534d4100000402a00000000100220010606508a0ffffffffffff00037800%s000300000000d7840e01fdffffffffff00000000' % (struct.pack('<I', src_serial).encode('hex'))
cmd_query_total_today = '534d4100000402a00000000100260010606509e0b500%s00007800%s000000000000f1b10002005400002600ffff260000000000' % (struct.pack('<I', dst_serial).encode('hex'), struct.pack('<I', src_serial).encode('hex'))
cmd_query_spot_ac_power = '534d4100000402a00000000100260010606509e0b500%s00007800%s00000000000081f00002005100002600ffff260000000000' % (struct.pack('<I', dst_serial).encode('hex'), struct.pack('<I', src_serial).encode('hex'))


sma_data = {}

query_list = []
rea = 0

class MulticastClientUDP(DatagramProtocol):

   def datagramReceived(self, datagram, address):
      global sma_data, data_available
      data = datagram.encode('hex')

      code = get_code(datagram)      
      if code == code_login:

         send_command(cmd_query_total_today)
      if code == code_total_today:
         total = get_long_value_at(datagram, 62)
         today = get_long_value_at(datagram, 78)
         print "total: %d" % total
         print "today: %d" % today
         sma_data['total'] = total
         sma_data['today'] = today

         send_command(cmd_query_spot_ac_power)
      if code == code_spot_ac_power:
         pvwatt = get_long_value_at(datagram, 62)
         if pvwatt == 0x80000000:
            pvwatt = 0
         print "pvwatt: %d" % pvwatt
         sma_data['spotacpower'] = pvwatt

         reactor.stop()

def send_command(cmd):
   data = cmd.decode('hex')
   rea.write(data, (comm_dst, comm_port))
   
def get_code(data):
   c = unpack('I', data[42:46])
   return c[0]   

def get_long_value_at(data, index):
   v = unpack('I', data[index:index+4])
   return v[0]

def callfunc(x):
    reactor.stop()
    
rea = reactor.listenUDP(0, MulticastClientUDP())
_DelayedCallObj = reactor.callLater(5, callfunc, "callfunc called after 4 sec")
send_command(cmd_login)
reactor.run()

Code: Alles auswählen

comm_dst = '192.168.2.123'
user_pw = '0000' # default is '0000'