d3ee35272d
Add batteryPriority setting Add battery soc reading to PowerWall Add battery soc reading to generic meter Publish batterySoC vaue when read
132 lines
3.2 KiB
Go
132 lines
3.2 KiB
Go
package meter
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
|
|
"github.com/andig/evcc/api"
|
|
"github.com/andig/evcc/provider"
|
|
"github.com/andig/evcc/util"
|
|
)
|
|
|
|
func init() {
|
|
registry.Add("default", NewConfigurableFromConfig)
|
|
}
|
|
|
|
//go:generate go run ../cmd/tools/decorate.go -p meter -f decorateMeter -b api.Meter -o meter_decorators -t "api.MeterEnergy,TotalEnergy,func() (float64, error)" -t "api.MeterCurrent,Currents,func() (float64, float64, float64, error)" -t "api.Battery,SoC,func() (float64, error)"
|
|
|
|
// NewConfigurableFromConfig creates api.Meter from config
|
|
func NewConfigurableFromConfig(other map[string]interface{}) (api.Meter, error) {
|
|
cc := struct {
|
|
Power provider.Config
|
|
Energy *provider.Config // optional
|
|
SoC *provider.Config // optional
|
|
Currents []provider.Config // optional
|
|
}{}
|
|
|
|
if err := util.DecodeOther(other, &cc); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
for k, v := range map[string]string{"power": cc.Power.Type} {
|
|
if v == "" {
|
|
return nil, fmt.Errorf("default meter config: %s required", k)
|
|
}
|
|
}
|
|
|
|
power, err := provider.NewFloatGetterFromConfig(cc.Power)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
m, _ := NewConfigurable(power)
|
|
|
|
// decorate Meter with MeterEnergy
|
|
var totalEnergy func() (float64, error)
|
|
if cc.Energy != nil {
|
|
m.totalEnergyG, err = provider.NewFloatGetterFromConfig(*cc.Energy)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
totalEnergy = m.totalEnergy
|
|
}
|
|
|
|
// decorate Meter with MeterCurrent
|
|
var currents func() (float64, float64, float64, error)
|
|
if len(cc.Currents) > 0 {
|
|
if len(cc.Currents) != 3 {
|
|
return nil, errors.New("need 3 currents")
|
|
}
|
|
|
|
for _, cc := range cc.Currents {
|
|
c, err := provider.NewFloatGetterFromConfig(cc)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
m.currentsG = append(m.currentsG, c)
|
|
}
|
|
|
|
currents = m.currents
|
|
}
|
|
|
|
// decorate Meter with BatterySoC
|
|
var batterySoC func() (float64, error)
|
|
if cc.SoC != nil {
|
|
m.batterySoCG, err = provider.NewFloatGetterFromConfig(*cc.SoC)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
batterySoC = m.batterySoC
|
|
}
|
|
|
|
res := decorateMeter(m, totalEnergy, currents, batterySoC)
|
|
|
|
return res, nil
|
|
}
|
|
|
|
// NewConfigurable creates a new meter
|
|
func NewConfigurable(currentPowerG func() (float64, error)) (*Meter, error) {
|
|
m := &Meter{
|
|
currentPowerG: currentPowerG,
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
// Meter is an api.Meter implementation with configurable getters and setters.
|
|
type Meter struct {
|
|
currentPowerG func() (float64, error)
|
|
totalEnergyG func() (float64, error)
|
|
currentsG []func() (float64, error)
|
|
batterySoCG func() (float64, error)
|
|
}
|
|
|
|
// CurrentPower implements the Meter.CurrentPower interface
|
|
func (m *Meter) CurrentPower() (float64, error) {
|
|
return m.currentPowerG()
|
|
}
|
|
|
|
// totalEnergy implements the Meter.TotalEnergy interface
|
|
func (m *Meter) totalEnergy() (float64, error) {
|
|
return m.totalEnergyG()
|
|
}
|
|
|
|
// currents implements the Meter.Currents interface
|
|
func (m *Meter) currents() (float64, float64, float64, error) {
|
|
var currents []float64
|
|
for _, currentG := range m.currentsG {
|
|
c, err := currentG()
|
|
if err != nil {
|
|
return 0, 0, 0, err
|
|
}
|
|
|
|
currents = append(currents, c)
|
|
}
|
|
|
|
return currents[0], currents[1], currents[2], nil
|
|
}
|
|
|
|
// batterySoC implements the Battery.SoC interface
|
|
func (m *Meter) batterySoC() (float64, error) {
|
|
return m.batterySoCG()
|
|
}
|