Add Phoenix CHARX chargers (#7040)
This commit is contained in:
andig
GitHub
parent
d49d90ba79
commit
bbe8e28b8c
2 changed files with 559 additions and 0 deletions
278
charger/phoenix-charx.go
Normal file
278
charger/phoenix-charx.go
Normal file
|
|
@ -0,0 +1,278 @@
|
|||
package charger
|
||||
|
||||
import (
|
||||
"encoding/binary"
|
||||
"fmt"
|
||||
"time"
|
||||
|
||||
"github.com/evcc-io/evcc/api"
|
||||
"github.com/evcc-io/evcc/util"
|
||||
"github.com/evcc-io/evcc/util/modbus"
|
||||
"github.com/volkszaehler/mbmd/encoding"
|
||||
)
|
||||
|
||||
const (
|
||||
// holding and input return same values
|
||||
charxRegName = 100
|
||||
charxRegSwVersion = 110
|
||||
charxRegNumControllers = 114
|
||||
|
||||
// per-unit registers
|
||||
charxOffset = 1000
|
||||
|
||||
charxRegMeter = 112
|
||||
charxRegVoltages = 232 // mV
|
||||
charxRegCurrents = 238 // mA
|
||||
charxRegPower = 244 // mW
|
||||
charxRegEnergy = 250 // Wh
|
||||
charxRegSoc = 264 // %
|
||||
charxRegEvid = 265 // 10
|
||||
charxRegRfid = 275 // 10
|
||||
charxRegChargeTime = 287 // s
|
||||
charxRegChargeEnergy = 289 // Wh
|
||||
charxRegStatus = 299 // IEC 61851-1
|
||||
charxRegEnable = 300
|
||||
charxRegMaxCurrent = 301 // A
|
||||
)
|
||||
|
||||
// PhoenixCharx is an api.Charger implementation for Phoenix CHARX controller
|
||||
type PhoenixCharx struct {
|
||||
conn *modbus.Connection
|
||||
connector uint16
|
||||
}
|
||||
|
||||
func init() {
|
||||
registry.Add("phoenix-charx", NewPhoenixCharxFromConfig)
|
||||
}
|
||||
|
||||
//go:generate go run ../cmd/tools/decorate.go -f decoratePhoenixCharx -b *PhoenixCharx -r api.Charger -t "api.Meter,CurrentPower,func() (float64, error)" -t "api.MeterEnergy,TotalEnergy,func() (float64, error)" -t "api.PhaseCurrents,Currents,func() (float64, float64, float64, error)" -t "api.PhaseVoltages,Voltages,func() (float64, float64, float64, error)"
|
||||
|
||||
// NewPhoenixCharxFromConfig creates a Phoenix charger from generic config
|
||||
func NewPhoenixCharxFromConfig(other map[string]interface{}) (api.Charger, error) {
|
||||
cc := struct {
|
||||
modbus.TcpSettings `mapstructure:",squash"`
|
||||
Connector uint16
|
||||
}{
|
||||
TcpSettings: modbus.TcpSettings{
|
||||
ID: 1, // default
|
||||
},
|
||||
Connector: 1,
|
||||
}
|
||||
|
||||
if err := util.DecodeOther(other, &cc); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
wb, err := NewPhoenixCharx(cc.URI, cc.ID, cc.Connector)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
meter, err := wb.meter()
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
if meter > 0 && meter != 65535 {
|
||||
return decoratePhoenixCharx(wb, wb.currentPower, wb.totalEnergy, wb.currents, wb.voltages), nil
|
||||
}
|
||||
|
||||
return wb, nil
|
||||
}
|
||||
|
||||
// NewPhoenixCharx creates a Phoenix charger
|
||||
func NewPhoenixCharx(uri string, id uint8, connector uint16) (*PhoenixCharx, error) {
|
||||
conn, err := modbus.NewConnection(uri, "", "", 0, modbus.Tcp, id)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
log := util.NewLogger("charx")
|
||||
conn.Logger(log.TRACE)
|
||||
|
||||
wb := &PhoenixCharx{
|
||||
conn: conn,
|
||||
connector: connector,
|
||||
}
|
||||
|
||||
controllers, err := wb.controllers()
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
if connector > controllers {
|
||||
return nil, fmt.Errorf("invalid connector: %d", connector)
|
||||
}
|
||||
|
||||
return wb, err
|
||||
}
|
||||
|
||||
func (wb *PhoenixCharx) controllers() (uint16, error) {
|
||||
b, err := wb.conn.ReadHoldingRegisters(charxRegNumControllers, 1)
|
||||
if err != nil {
|
||||
return 0, err
|
||||
}
|
||||
|
||||
return binary.BigEndian.Uint16(b), nil
|
||||
}
|
||||
|
||||
func (wb *PhoenixCharx) register(reg uint16) uint16 {
|
||||
return wb.connector*charxOffset + reg
|
||||
}
|
||||
|
||||
func (wb *PhoenixCharx) meter() (uint16, error) {
|
||||
b, err := wb.conn.ReadHoldingRegisters(wb.register(charxRegMeter), 1)
|
||||
if err != nil {
|
||||
return 0, err
|
||||
}
|
||||
|
||||
return encoding.Uint16(b), nil
|
||||
}
|
||||
|
||||
// Status implements the api.Charger interface
|
||||
func (wb *PhoenixCharx) Status() (api.ChargeStatus, error) {
|
||||
b, err := wb.conn.ReadHoldingRegisters(wb.register(charxRegStatus), 1)
|
||||
if err != nil {
|
||||
return api.StatusNone, err
|
||||
}
|
||||
|
||||
// TODO check IEC 61851-1 C1 state
|
||||
state := string(b[0])
|
||||
|
||||
return api.ChargeStatus(state), nil
|
||||
}
|
||||
|
||||
// Enabled implements the api.Charger interface
|
||||
func (wb *PhoenixCharx) Enabled() (bool, error) {
|
||||
b, err := wb.conn.ReadHoldingRegisters(wb.register(charxRegEnable), 1)
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
return encoding.Uint16(b) == 1, nil
|
||||
}
|
||||
|
||||
// Enable implements the api.Charger interface
|
||||
func (wb *PhoenixCharx) Enable(enable bool) error {
|
||||
b := make([]byte, 2)
|
||||
if enable {
|
||||
binary.BigEndian.PutUint16(b, 1)
|
||||
}
|
||||
|
||||
_, err := wb.conn.WriteMultipleRegisters(wb.register(charxRegEnable), 1, b)
|
||||
|
||||
return err
|
||||
}
|
||||
|
||||
// MaxCurrent implements the api.Charger interface
|
||||
func (wb *PhoenixCharx) MaxCurrent(current int64) error {
|
||||
if current < 6 {
|
||||
return fmt.Errorf("invalid current %d", current)
|
||||
}
|
||||
|
||||
b := make([]byte, 2)
|
||||
binary.BigEndian.PutUint16(b, uint16(current))
|
||||
|
||||
_, err := wb.conn.WriteMultipleRegisters(wb.register(charxRegMaxCurrent), 1, b)
|
||||
|
||||
return err
|
||||
}
|
||||
|
||||
var _ api.ChargeTimer = (*PhoenixCharx)(nil)
|
||||
|
||||
// ChargingTime implements the api.ChargeTimer interface
|
||||
func (wb *PhoenixCharx) ChargingTime() (time.Duration, error) {
|
||||
b, err := wb.conn.ReadHoldingRegisters(wb.register(charxRegChargeTime), 2)
|
||||
if err != nil {
|
||||
return 0, err
|
||||
}
|
||||
|
||||
return time.Duration(encoding.Uint16(b)) * time.Second, nil
|
||||
}
|
||||
|
||||
// currentPower implements the api.Meter interface
|
||||
func (wb *PhoenixCharx) currentPower() (float64, error) {
|
||||
b, err := wb.conn.ReadHoldingRegisters(wb.register(charxRegPower), 2)
|
||||
if err != nil {
|
||||
return 0, err
|
||||
}
|
||||
|
||||
return float64(encoding.Int32(b)) / 1e3, nil
|
||||
}
|
||||
|
||||
// totalEnergy implements the api.MeterEnergy interface
|
||||
func (wb *PhoenixCharx) totalEnergy() (float64, error) {
|
||||
b, err := wb.conn.ReadHoldingRegisters(wb.register(charxRegEnergy), 4)
|
||||
if err != nil {
|
||||
return 0, err
|
||||
}
|
||||
|
||||
return float64(encoding.Int64(b)) / 1e3, nil
|
||||
}
|
||||
|
||||
// currents implements the api.PhaseCurrents interface
|
||||
func (wb *PhoenixCharx) currents() (float64, float64, float64, error) {
|
||||
b, err := wb.conn.ReadHoldingRegisters(wb.register(charxRegCurrents), 3*2)
|
||||
if err != nil {
|
||||
return 0, 0, 0, err
|
||||
}
|
||||
|
||||
return float64(encoding.Int32(b)) / 1e3,
|
||||
float64(encoding.Int32(b[4:])) / 1e3,
|
||||
float64(encoding.Int32(b[8:])) / 1e3, nil
|
||||
}
|
||||
|
||||
// voltages implements the api.PhaseVoltages interface
|
||||
func (wb *PhoenixCharx) voltages() (float64, float64, float64, error) {
|
||||
b, err := wb.conn.ReadHoldingRegisters(wb.register(charxRegVoltages), 3*2)
|
||||
if err != nil {
|
||||
return 0, 0, 0, err
|
||||
}
|
||||
|
||||
return float64(encoding.Int32(b)) / 1e3,
|
||||
float64(encoding.Int32(b[4:])) / 1e3,
|
||||
float64(encoding.Int32(b[8:])) / 1e3, nil
|
||||
}
|
||||
|
||||
var _ api.Identifier = (*PhoenixCharx)(nil)
|
||||
|
||||
// Identify implements the api.Identifier interface
|
||||
func (wb *PhoenixCharx) Identify() (string, error) {
|
||||
b, err := wb.conn.ReadHoldingRegisters(wb.register(charxRegEvid), 10)
|
||||
if err != nil {
|
||||
return "", err
|
||||
}
|
||||
|
||||
if res := bytesAsString(b); res != "" {
|
||||
return res, nil
|
||||
}
|
||||
|
||||
b, err = wb.conn.ReadHoldingRegisters(wb.register(charxRegRfid), 10)
|
||||
if err != nil {
|
||||
return "", err
|
||||
}
|
||||
|
||||
return bytesAsString(b), nil
|
||||
}
|
||||
|
||||
var _ api.Diagnosis = (*PhoenixCharx)(nil)
|
||||
|
||||
// Diagnose implements the api.Diagnosis interface
|
||||
func (wb *PhoenixCharx) Diagnose() {
|
||||
if b, err := wb.conn.ReadHoldingRegisters(charxRegName, 10); err == nil {
|
||||
fmt.Printf("Name: %s\n", b)
|
||||
}
|
||||
if b, err := wb.conn.ReadHoldingRegisters(charxRegSwVersion, 4); err == nil {
|
||||
fmt.Printf("Software version: %s\n", b)
|
||||
}
|
||||
|
||||
controllers, err := wb.controllers()
|
||||
if err == nil {
|
||||
fmt.Printf("Controllers: %d\n", controllers)
|
||||
}
|
||||
|
||||
meter, err := wb.meter()
|
||||
if err == nil {
|
||||
fmt.Printf("Meter: %d\n", meter)
|
||||
}
|
||||
}
|
||||
281
charger/phoenix-charx_decorators.go
Normal file
281
charger/phoenix-charx_decorators.go
Normal file
|
|
@ -0,0 +1,281 @@
|
|||
package charger
|
||||
|
||||
// Code generated by github.com/evcc-io/evcc/cmd/tools/decorate.go. DO NOT EDIT.
|
||||
|
||||
import (
|
||||
"github.com/evcc-io/evcc/api"
|
||||
)
|
||||
|
||||
func decoratePhoenixCharx(base *PhoenixCharx, meter func() (float64, error), meterEnergy func() (float64, error), phaseCurrents func() (float64, float64, float64, error), phaseVoltages func() (float64, float64, float64, error)) api.Charger {
|
||||
switch {
|
||||
case meter == nil && meterEnergy == nil && phaseCurrents == nil && phaseVoltages == nil:
|
||||
return base
|
||||
|
||||
case meter != nil && meterEnergy == nil && phaseCurrents == nil && phaseVoltages == nil:
|
||||
return &struct {
|
||||
*PhoenixCharx
|
||||
api.Meter
|
||||
}{
|
||||
PhoenixCharx: base,
|
||||
Meter: &decoratePhoenixCharxMeterImpl{
|
||||
meter: meter,
|
||||
},
|
||||
}
|
||||
|
||||
case meter == nil && meterEnergy != nil && phaseCurrents == nil && phaseVoltages == nil:
|
||||
return &struct {
|
||||
*PhoenixCharx
|
||||
api.MeterEnergy
|
||||
}{
|
||||
PhoenixCharx: base,
|
||||
MeterEnergy: &decoratePhoenixCharxMeterEnergyImpl{
|
||||
meterEnergy: meterEnergy,
|
||||
},
|
||||
}
|
||||
|
||||
case meter != nil && meterEnergy != nil && phaseCurrents == nil && phaseVoltages == nil:
|
||||
return &struct {
|
||||
*PhoenixCharx
|
||||
api.Meter
|
||||
api.MeterEnergy
|
||||
}{
|
||||
PhoenixCharx: base,
|
||||
Meter: &decoratePhoenixCharxMeterImpl{
|
||||
meter: meter,
|
||||
},
|
||||
MeterEnergy: &decoratePhoenixCharxMeterEnergyImpl{
|
||||
meterEnergy: meterEnergy,
|
||||
},
|
||||
}
|
||||
|
||||
case meter == nil && meterEnergy == nil && phaseCurrents != nil && phaseVoltages == nil:
|
||||
return &struct {
|
||||
*PhoenixCharx
|
||||
api.PhaseCurrents
|
||||
}{
|
||||
PhoenixCharx: base,
|
||||
PhaseCurrents: &decoratePhoenixCharxPhaseCurrentsImpl{
|
||||
phaseCurrents: phaseCurrents,
|
||||
},
|
||||
}
|
||||
|
||||
case meter != nil && meterEnergy == nil && phaseCurrents != nil && phaseVoltages == nil:
|
||||
return &struct {
|
||||
*PhoenixCharx
|
||||
api.Meter
|
||||
api.PhaseCurrents
|
||||
}{
|
||||
PhoenixCharx: base,
|
||||
Meter: &decoratePhoenixCharxMeterImpl{
|
||||
meter: meter,
|
||||
},
|
||||
PhaseCurrents: &decoratePhoenixCharxPhaseCurrentsImpl{
|
||||
phaseCurrents: phaseCurrents,
|
||||
},
|
||||
}
|
||||
|
||||
case meter == nil && meterEnergy != nil && phaseCurrents != nil && phaseVoltages == nil:
|
||||
return &struct {
|
||||
*PhoenixCharx
|
||||
api.MeterEnergy
|
||||
api.PhaseCurrents
|
||||
}{
|
||||
PhoenixCharx: base,
|
||||
MeterEnergy: &decoratePhoenixCharxMeterEnergyImpl{
|
||||
meterEnergy: meterEnergy,
|
||||
},
|
||||
PhaseCurrents: &decoratePhoenixCharxPhaseCurrentsImpl{
|
||||
phaseCurrents: phaseCurrents,
|
||||
},
|
||||
}
|
||||
|
||||
case meter != nil && meterEnergy != nil && phaseCurrents != nil && phaseVoltages == nil:
|
||||
return &struct {
|
||||
*PhoenixCharx
|
||||
api.Meter
|
||||
api.MeterEnergy
|
||||
api.PhaseCurrents
|
||||
}{
|
||||
PhoenixCharx: base,
|
||||
Meter: &decoratePhoenixCharxMeterImpl{
|
||||
meter: meter,
|
||||
},
|
||||
MeterEnergy: &decoratePhoenixCharxMeterEnergyImpl{
|
||||
meterEnergy: meterEnergy,
|
||||
},
|
||||
PhaseCurrents: &decoratePhoenixCharxPhaseCurrentsImpl{
|
||||
phaseCurrents: phaseCurrents,
|
||||
},
|
||||
}
|
||||
|
||||
case meter == nil && meterEnergy == nil && phaseCurrents == nil && phaseVoltages != nil:
|
||||
return &struct {
|
||||
*PhoenixCharx
|
||||
api.PhaseVoltages
|
||||
}{
|
||||
PhoenixCharx: base,
|
||||
PhaseVoltages: &decoratePhoenixCharxPhaseVoltagesImpl{
|
||||
phaseVoltages: phaseVoltages,
|
||||
},
|
||||
}
|
||||
|
||||
case meter != nil && meterEnergy == nil && phaseCurrents == nil && phaseVoltages != nil:
|
||||
return &struct {
|
||||
*PhoenixCharx
|
||||
api.Meter
|
||||
api.PhaseVoltages
|
||||
}{
|
||||
PhoenixCharx: base,
|
||||
Meter: &decoratePhoenixCharxMeterImpl{
|
||||
meter: meter,
|
||||
},
|
||||
PhaseVoltages: &decoratePhoenixCharxPhaseVoltagesImpl{
|
||||
phaseVoltages: phaseVoltages,
|
||||
},
|
||||
}
|
||||
|
||||
case meter == nil && meterEnergy != nil && phaseCurrents == nil && phaseVoltages != nil:
|
||||
return &struct {
|
||||
*PhoenixCharx
|
||||
api.MeterEnergy
|
||||
api.PhaseVoltages
|
||||
}{
|
||||
PhoenixCharx: base,
|
||||
MeterEnergy: &decoratePhoenixCharxMeterEnergyImpl{
|
||||
meterEnergy: meterEnergy,
|
||||
},
|
||||
PhaseVoltages: &decoratePhoenixCharxPhaseVoltagesImpl{
|
||||
phaseVoltages: phaseVoltages,
|
||||
},
|
||||
}
|
||||
|
||||
case meter != nil && meterEnergy != nil && phaseCurrents == nil && phaseVoltages != nil:
|
||||
return &struct {
|
||||
*PhoenixCharx
|
||||
api.Meter
|
||||
api.MeterEnergy
|
||||
api.PhaseVoltages
|
||||
}{
|
||||
PhoenixCharx: base,
|
||||
Meter: &decoratePhoenixCharxMeterImpl{
|
||||
meter: meter,
|
||||
},
|
||||
MeterEnergy: &decoratePhoenixCharxMeterEnergyImpl{
|
||||
meterEnergy: meterEnergy,
|
||||
},
|
||||
PhaseVoltages: &decoratePhoenixCharxPhaseVoltagesImpl{
|
||||
phaseVoltages: phaseVoltages,
|
||||
},
|
||||
}
|
||||
|
||||
case meter == nil && meterEnergy == nil && phaseCurrents != nil && phaseVoltages != nil:
|
||||
return &struct {
|
||||
*PhoenixCharx
|
||||
api.PhaseCurrents
|
||||
api.PhaseVoltages
|
||||
}{
|
||||
PhoenixCharx: base,
|
||||
PhaseCurrents: &decoratePhoenixCharxPhaseCurrentsImpl{
|
||||
phaseCurrents: phaseCurrents,
|
||||
},
|
||||
PhaseVoltages: &decoratePhoenixCharxPhaseVoltagesImpl{
|
||||
phaseVoltages: phaseVoltages,
|
||||
},
|
||||
}
|
||||
|
||||
case meter != nil && meterEnergy == nil && phaseCurrents != nil && phaseVoltages != nil:
|
||||
return &struct {
|
||||
*PhoenixCharx
|
||||
api.Meter
|
||||
api.PhaseCurrents
|
||||
api.PhaseVoltages
|
||||
}{
|
||||
PhoenixCharx: base,
|
||||
Meter: &decoratePhoenixCharxMeterImpl{
|
||||
meter: meter,
|
||||
},
|
||||
PhaseCurrents: &decoratePhoenixCharxPhaseCurrentsImpl{
|
||||
phaseCurrents: phaseCurrents,
|
||||
},
|
||||
PhaseVoltages: &decoratePhoenixCharxPhaseVoltagesImpl{
|
||||
phaseVoltages: phaseVoltages,
|
||||
},
|
||||
}
|
||||
|
||||
case meter == nil && meterEnergy != nil && phaseCurrents != nil && phaseVoltages != nil:
|
||||
return &struct {
|
||||
*PhoenixCharx
|
||||
api.MeterEnergy
|
||||
api.PhaseCurrents
|
||||
api.PhaseVoltages
|
||||
}{
|
||||
PhoenixCharx: base,
|
||||
MeterEnergy: &decoratePhoenixCharxMeterEnergyImpl{
|
||||
meterEnergy: meterEnergy,
|
||||
},
|
||||
PhaseCurrents: &decoratePhoenixCharxPhaseCurrentsImpl{
|
||||
phaseCurrents: phaseCurrents,
|
||||
},
|
||||
PhaseVoltages: &decoratePhoenixCharxPhaseVoltagesImpl{
|
||||
phaseVoltages: phaseVoltages,
|
||||
},
|
||||
}
|
||||
|
||||
case meter != nil && meterEnergy != nil && phaseCurrents != nil && phaseVoltages != nil:
|
||||
return &struct {
|
||||
*PhoenixCharx
|
||||
api.Meter
|
||||
api.MeterEnergy
|
||||
api.PhaseCurrents
|
||||
api.PhaseVoltages
|
||||
}{
|
||||
PhoenixCharx: base,
|
||||
Meter: &decoratePhoenixCharxMeterImpl{
|
||||
meter: meter,
|
||||
},
|
||||
MeterEnergy: &decoratePhoenixCharxMeterEnergyImpl{
|
||||
meterEnergy: meterEnergy,
|
||||
},
|
||||
PhaseCurrents: &decoratePhoenixCharxPhaseCurrentsImpl{
|
||||
phaseCurrents: phaseCurrents,
|
||||
},
|
||||
PhaseVoltages: &decoratePhoenixCharxPhaseVoltagesImpl{
|
||||
phaseVoltages: phaseVoltages,
|
||||
},
|
||||
}
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
type decoratePhoenixCharxMeterImpl struct {
|
||||
meter func() (float64, error)
|
||||
}
|
||||
|
||||
func (impl *decoratePhoenixCharxMeterImpl) CurrentPower() (float64, error) {
|
||||
return impl.meter()
|
||||
}
|
||||
|
||||
type decoratePhoenixCharxMeterEnergyImpl struct {
|
||||
meterEnergy func() (float64, error)
|
||||
}
|
||||
|
||||
func (impl *decoratePhoenixCharxMeterEnergyImpl) TotalEnergy() (float64, error) {
|
||||
return impl.meterEnergy()
|
||||
}
|
||||
|
||||
type decoratePhoenixCharxPhaseCurrentsImpl struct {
|
||||
phaseCurrents func() (float64, float64, float64, error)
|
||||
}
|
||||
|
||||
func (impl *decoratePhoenixCharxPhaseCurrentsImpl) Currents() (float64, float64, float64, error) {
|
||||
return impl.phaseCurrents()
|
||||
}
|
||||
|
||||
type decoratePhoenixCharxPhaseVoltagesImpl struct {
|
||||
phaseVoltages func() (float64, float64, float64, error)
|
||||
}
|
||||
|
||||
func (impl *decoratePhoenixCharxPhaseVoltagesImpl) Voltages() (float64, float64, float64, error) {
|
||||
return impl.phaseVoltages()
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue