Pixelmagic blog

# Install some required packages first
sudo apt update
sudo apt install -y \
     apt-transport-https \
     ca-certificates \
     curl \
     gnupg2 \
     software-properties-common

# Get the Docker signing key for packages
curl -fsSL https://download.docker.com/linux/$(. /etc/os-release; echo "$ID")/gpg | sudo apt-key add -

# Add the Docker official repos
echo "deb [arch=$(dpkg --print-architecture)] https://download.docker.com/linux/$(. /etc/os-release; echo "$ID") \
     $(lsb_release -cs) stable" | \
    sudo tee /etc/apt/sources.list.d/docker.list

# Install Docker
sudo apt update
sudo apt install -y --no-install-recommends \
    docker-ce \
    cgroupfs-mount
    docker-compose

# Docker Compose
sudo usermod -aG docker $USER
sudo ln -s /usr/local/bin/docker-compose /usr/bin/docker-compose
sudo service docker restart

bluetoothctl scan on

wget https://raw.githubusercontent.com/jshridha/inkbird/master/docker-compose.yaml

sudo docker-compose up -d

(float)inv[i]->Temperature/100 << ")" ;

(float)inv[i]->Temperature/100 << ',' <<
(float)inv[i]->Temperature/100 << ")" ;

ALTER TABLE `SpotData` ADD `Aardlekstroom` FLOAT NOT NULL AFTER `Temperature`;

#!/usr/bin/python3

import smamodbus
import re
import time
import config
import json

interval=10
# vul hier je eigen IP nummer van de SMA omvormer in 
MODBUS_URL = 'xxx.xxx.xxx.xxx'
MODBUS_UNIT_ID = 3

sma = smamodbus.SMAModbus(MODBUS_URL,MODBUS_UNIT_ID)

lastPVOutput = None

dataActual = sma.readModbus()

for tag,v in dataActual.items():
    dataActual[tag] = float(v)
    #print(tag,dataActual[tag])

data = json.dumps(dataActual)
print(data)

quit()

from pymodbus.client.sync import ModbusTcpClient
import logging
import struct
modbus_fields = {
    'ETotal': {'address': 30529, 'datatype': 'U32', 'scale': 1, 'unit': 'kWh','min': 0,'max': 4000.*100},
    'TempHeatsink': {'address': 30953, 'datatype': 'S32', 'scale': 10, 'unit': 'C','min': 0,'max': 200.},
    'Status': {'address': 40029, 'datatype': 'U32', 'scale': 1, 'unit': '','min': 0,'max':16777213},

    'DCPower': {'address': 30773, 'datatype': 'S32', 'scale': 1, 'unit': 'kWh','min': 0,'max': 4e3},
    'DCVoltage': {'address': 30771, 'datatype': 'S32', 'scale': 100, 'unit': 'V','min': 0,'max': 1e3},
    'DCCurrent': {'address': 30769, 'datatype': 'S32', 'scale': 1000, 'unit': 'A','min': 0,'max': 100.},

    'AC1Power': {'address': 30777, 'datatype': 'U32', 'scale': 1, 'unit': 'kW','min': 0,'max': 1e4},
    'AC1Voltage': {'address': 30783, 'datatype': 'U32', 'scale': 100, 'unit': 'V','min': 0,'max': 500.},
    'AC1Current': {'address': 30977, 'datatype': 'S32', 'scale': 1000, 'unit': 'A','min': 0,'max': 100.},

    'AC2Power': {'address': 30779, 'datatype': 'U32', 'scale': 1, 'unit': 'kW','min': 0,'max': 1e4},
    'AC2Voltage': {'address': 30785, 'datatype': 'U32', 'scale': 100, 'unit': 'V','min': 0,'max': 500.},
    'AC2Current': {'address': 30979, 'datatype': 'S32', 'scale': 1000, 'unit': 'A','min': 0,'max': 100.},

    'AC3Power': {'address': 30981, 'datatype': 'S32', 'scale': 1000, 'unit': 'A','min': 0,'max': 100.},
    'AC3Voltage': {'address': 30787, 'datatype': 'U32', 'scale': 100, 'unit': 'V','min': 0,'max': 500.},
    'AC3Current': {'address': 30981, 'datatype': 'S32', 'scale': 1000, 'unit': 'A','min': 0,'max': 100.},

    'Aardlekstroom': {'address': 31247, 'datatype': 'S32', 'scale': 100, 'unit': 'A','min': 0,'max': 1000.},


}

class SMAModbus:
    def __init__(self,url,unit_id):
        logging.info('Connecting to Modbus server: {}'.format(url))
        # hier nogmaals je eigen IP nummer van SMA omvormer invullen
        self._client = ModbusTcpClient('xxx.xxx.xxx.xxx')
        self._client.connect()
        logging.info('Connected')
        self._unit_id = unit_id

    def readModbus(self):
        if not self._client.is_socket_open():
            self._client.connect()
        data = {}
        for tag,cfg in modbus_fields.items():
            result = self._client.read_holding_registers(cfg['address'], 2, unit=self._unit_id)
            if result.isError():
                logging.error('Reading registers for {} gave an error'.format(tag))
                continue
            w1 = struct.pack('H', result.registers[0]) # Assuming register values are unsigned short's
            w2 = struct.pack('H', result.registers[1]) # Assuming register values are unsigned short's
            if cfg['datatype'] == 'S32':
                v = struct.unpack('i', w2 + w1)
            elif cfg['datatype'] == 'U32':
                v = struct.unpack('I', w2 + w1)
            else:
                raise NotImplementedError('Datatype {} is not implemented'.format(cfg['datatype']))
            v = v[0]/cfg['scale']
            if v<cfg['min'] or v>cfg['max']:
                logging.error('Value out of range for {}: {} < {} < {} [{}]'.format(tag,cfg['min'],v,cfg['max'],cfg['unit']))
                logging.error('Raw data: {}.{}'.format(result.registers[0],result.registers[1]))
                #skip output
                continue
            v =  (result.registers[0]*2**16+result.registers[1])/cfg['scale']
            # check for negative or larger than 100y of output
            if v<0 or v>100*3000*1000:
                v=0.
            data[tag] = v
        return data

<?php
$servername = "dbserver";
$username = "username";
$password = "password";

// Create connection
$db = new mysqli($servername, $username, $password);

// Check connection
if ($db->connect_error) {
    die("DB Connection failed: " . $db->connect_error);
}
?>

<?php
require_once('/pad_naar/mysqli.inc.php');
/*
40029 status waardes:
    295: MPP (Mpp)
    381: Stop (Stop)
    443: Constante spanning (VolDCConst)
    455: Waarschuwing (Wrn)
    1392: Fout (Flt)
    1393: Wacht op PV-spanning (WaitPV)
    1467: Start (Str)
    1469: Uitschakelen (Shtdwn)
    1480: Wacht op energieleverancier (WaitUtil)
    2119: Afregeling (Drt)
    16777213: (NaNStt)

*/

echo '<pre>';
echo date("d-m-Y H:i:s").chr(10);
# 10 seconde wachten zodat cron job op SFBspot gedraaid heeft
if (!ISSET($_SERVER['HTTP_USER_AGENT'])) sleep(10);
# laatste insert van SpotData ophalen
$sql = "SELECT * FROM `SBFspot`.`SpotData` ORDER BY `SpotData`.`TimeStamp` DESC  LIMIT 1";
$result = mysqli_query($db,$sql) or die("Error: " . mysqli_error($db));
$row = mysqli_fetch_array($result);
$cur_datetime = date("d-m-Y H:i");
$last_datetime = date("d-m-Y H:i",$row['TimeStamp']);
$last_timestamp = $row['TimeStamp'];
$last_dc_power = $row['Pdc1'];
$last_etotal = $row['ETotal'];
# maximum verschil in etotal
$diff_etotal = 50;

# locatie van het python script
$command = escapeshellcmd('/var/www/192.168.1.13/modbus/smalogger.py');
# data ophalen van python modbus script
$output = shell_exec($command);

# json omzetten naar array
$data = json_decode($output, true);

# array sorteren op naam
ksort($data);

if ($cur_datetime == $last_datetime) {
    echo 'Minuut identiek'.chr(10);
    #if ($last_etotal == $data['ETotal']) {
    if (abs($last_etotal - $data['ETotal']) < $diff_etotal) {
        echo 'DC Power identiek binnen '.$diff_etotal.' ('.$last_etotal.' '.$data['ETotal'].')'.chr(10);
        $temp = $data['TempHeatsink'];
        $aardlek = $data['Aardlekstroom'];
        # update van temp doen
        $sql = "UPDATE `SBFspot`.`SpotData` SET 
                `Temperature` = '$temp',
                `Aardlekstroom` = '$aardlek'
                WHERE `SpotData`.`TimeStamp` = '$last_timestamp';";
        $result = mysqli_query($db,$sql) or die("Error: " . mysqli_error($db));
    } else {
        echo $last_etotal.' '.$data['ETotal'].chr(10);
        echo abs($last_etotal - $data['ETotal']);
    }   
}
?>