EM2GO Home: Workaround for old fw current and phase setting

charger/em2go.go

@@ -23,6 +23,7 @@ import (
 	"time"
 
 	"github.com/evcc-io/evcc/api"
+	"github.com/evcc-io/evcc/core/loadpoint"
 	"github.com/evcc-io/evcc/util"
 	"github.com/evcc-io/evcc/util/modbus"
 	"github.com/volkszaehler/mbmd/meters/rs485"
@@ -32,8 +33,11 @@ import (
 
 // Em2Go charger implementation
 type Em2Go struct {
-	log  *util.Logger
-	conn *modbus.Connection
+	log        *util.Logger
+	conn       *modbus.Connection
+	current    int64
+	lp         loadpoint.API
+	workaround bool
 }
 
 const (
@@ -63,7 +67,7 @@ func init() {
 		return NewEm2GoFromConfig(other, true)
 	})
 	registry.Add("em2go-home", func(other map[string]any) (api.Charger, error) {
-		return NewEm2GoFromConfig(other, false)
+		return NewEm2GoFromConfig(other, true)
 	})
 }
 
@@ -98,25 +102,39 @@ func NewEm2Go(uri string, slaveID uint8, milli bool) (api.Charger, error) {
 	conn.Logger(log.TRACE)
 
 	wb := &Em2Go{
-		log:  log,
-		conn: conn,
+		log:        log,
+		conn:       conn,
+		current:    6,
+		workaround: false,
 	}
 
 	var (
-		maxCurrent func(float64) error
-		phases1p3p func(int) error
-		phasesG    func() (int, error)
+		maxCurrent     func(float64) error
+		phases1p3p     func(int) error
+		phasesG        func() (int, error)
+		chargerCurrent float64
 	)
 
-	if milli {
-		maxCurrent = wb.maxCurrentMillis
-	}
-
 	if _, err := wb.conn.ReadHoldingRegisters(em2GoRegPhases, 1); err == nil {
 		phases1p3p = wb.phases1p3p
 		phasesG = wb.getPhases
 	}
 
+	// Test if workaround is needed (Home fw <1.3)
+	if wb.maxCurrentMillis(6.1) != nil {
+		return nil, err
+	}
+	chargerCurrent, err = wb.GetMaxCurrent()
+
+	if chargerCurrent == 6 {
+		wb.workaround = true
+	} else {
+		wb.workaround = false
+		if milli {
+			maxCurrent = wb.maxCurrentMillis
+		}
+	}
+
 	return decorateEm2Go(wb, maxCurrent, phases1p3p, phasesG), err
 }
 
@@ -158,8 +176,32 @@ func (wb *Em2Go) Enable(enable bool) error {
 	b := make([]byte, 2)
 	binary.BigEndian.PutUint16(b, map[bool]uint16{true: 1, false: 2}[enable])
 
-	_, err := wb.conn.WriteMultipleRegisters(em2GoRegChargeCommand, 1, b)
-	return err
+	if _, err := wb.conn.WriteMultipleRegisters(em2GoRegChargeCommand, 1, b); err != nil {
+		return err
+	}
+
+	// Workaround
+	if wb.workaround {
+		//Get wanted phases set in lp and send to charger
+		var phases int
+		if wb.lp != nil {
+			phases = wb.lp.GetPhases()
+		}
+		if phases == 0 {
+			phases = 3
+		}
+		c := make([]byte, 2)
+		binary.BigEndian.PutUint16(c, uint16(phases))
+		if _, err := wb.conn.WriteMultipleRegisters(em2GoRegPhases, 1, c); err != nil {
+			return err
+		}
+
+		//Send default current to charger
+		var current int64
+		current = wb.current
+		wb.MaxCurrent(current)
+	}
+	return nil
 }
 
 // MaxCurrent implements the api.Charger interface
@@ -271,8 +313,31 @@ func (wb *Em2Go) phases1p3p(phases int) error {
 	b := make([]byte, 2)
 	binary.BigEndian.PutUint16(b, uint16(phases))
 
-	_, err := wb.conn.WriteMultipleRegisters(em2GoRegPhases, 1, b)
-	return err
+	//Workaround
+	if wb.workaround {
+		// When enabled, disable, wait 10 seconds, enable and set phases
+		enabled, err := wb.Enabled()
+		if err != nil {
+			return err
+		}
+
+		if enabled {
+			if err := wb.Enable(false); err != nil {
+				return err
+			}
+			time.Sleep(10 * time.Second)
+
+			if err := wb.Enable(true); err != nil {
+				return err
+			}
+		}
+	}
+
+	if _, err := wb.conn.WriteMultipleRegisters(em2GoRegPhases, 1, b); err != nil {
+		return err
+	}
+
+	return nil
 }
 
 // getPhases implements the api.PhaseGetter interface
@@ -332,3 +397,10 @@ func (wb *Em2Go) Diagnose() {
 		fmt.Printf("\tCharge Command:\t%d\n", binary.BigEndian.Uint16(b))
 	}
 }
+
+var _ loadpoint.Controller = (*Em2Go)(nil)
+
+// LoadpointControl implements loadpoint.Controller
+func (wb *Em2Go) LoadpointControl(lp loadpoint.API) {
+	wb.lp = lp
+}

templates/definition/charger/em2go-home.yaml

@@ -3,11 +3,11 @@ products:
   - brand: EM2GO
     description:
       generic: Home
-capabilities: ["1p3p"]
+capabilities: ["1p3p", "mA"]
 requirements:
   description:
-    de: "Benötigt Firmware version E3C_V1.1 oder neuer."
-    en: "Requires Firmware version E3C_V1.1 or newer."
+    de: "Benötigt FW version >= E3C_V1.1. mA Regelung benötigt FW version >= E3C_V1.3."
+    en: "Requires FW Version >= E3C_V1.1. mA regulation requires FW version >= E3C_V1.3."
 params:
   - name: host
 render: |