Stefan/evcc-io
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

EEBus: Fix Enabled handling, improve Status and connected handling, fix typo (#2956)

Browse source
This commit is contained in:
MarkusGH 2022-03-21 11:24:35 +01:00 • committed by GitHub
parent c5470e0c9f
commit bd91963286
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 31 additions and 29 deletions
Download patch file Download diff file Expand all files Collapse all files

60
charger/eebus.go
View file

@ -29,8 +29,9 @@ type EEBus struct {
socSupportAvailable bool
selfConsumptionSupportAvailable bool
maxCurrent float64
connected bool
maxCurrent float64
connected bool
expectedEnableState bool
evConnectedTime time.Time
}
@ -73,14 +74,14 @@ func NewEEBus(ski string, forcePVLimits bool) (*EEBus, error) {
}
func (c *EEBus) onConnect(ski string, conn ship.Conn) error {
c.log.TRACE.Println("!! onCconnect invoked on ski ", ski)
c.log.TRACE.Println("!! onConnect invoked on ski ", ski)
eebusDevice := app.HEMS(server.EEBusInstance.DeviceInfo())
c.cc = communication.NewConnectionController(c.log.TRACE, conn, eebusDevice)
c.cc.SetDataUpdateHandler(c.dataUpdateHandler)
c.connected = true
c.setDefaultValues()
c.setConnected(true)
err := c.cc.Boot()
@ -90,16 +91,24 @@ func (c *EEBus) onConnect(ski string, conn ship.Conn) error {
func (c *EEBus) onDisconnect(ski string) {
c.log.TRACE.Println("!! onDisconnect invoked on ski ", ski)
c.connected = false
c.setConnected(false)
c.setDefaultValues()
}
func (c *EEBus) setDefaultValues() {
c.expectedEnableState = false
c.communicationStandard = communication.EVCommunicationStandardEnumTypeUnknown
c.socSupportAvailable = false
c.selfConsumptionSupportAvailable = false
}
func (c *EEBus) setConnected(connected bool) {
if connected && !c.connected {
c.evConnectedTime = time.Now()
}
c.connected = connected
}
func (c *EEBus) setLoadpointMinMaxLimits(data *communication.EVSEClientDataType) {
if c.lp == nil {
return
@ -152,7 +161,7 @@ func (c *EEBus) showCurrentChargingSetup() {
func (c *EEBus) dataUpdateHandler(dataType communication.EVDataElementUpdateType, data *communication.EVSEClientDataType) {
// we receive data, so it is connected
c.connected = true
c.setConnected(true)
c.showCurrentChargingSetup()
@ -165,6 +174,9 @@ func (c *EEBus) dataUpdateHandler(dataType communication.EVDataElementUpdateType
}
// case communication.EVDataElementUpdateUseCaseSoC:
case communication.EVDataElementUpdateEVConnectionState:
if data.EVData.ChargeState == communication.EVChargeStateEnumTypeUnplugged {
c.expectedEnableState = false
}
c.setLoadpointMinMaxLimits(data)
case communication.EVDataElementUpdateCommunicationStandard:
c.communicationStandard = data.EVData.CommunicationStandard
@ -189,8 +201,7 @@ func isCharging(d communication.EVDataType) bool {
d.Measurements.PowerL3 > d.LimitsL3.Min*idleFactor
}
// Status implements the api.Charger interface
func (c *EEBus) Status() (api.ChargeStatus, error) {
func (c *EEBus) updateState() (api.ChargeStatus, error) {
data, err := c.cc.GetData()
if err != nil {
c.log.TRACE.Printf("!! status: no eebus data available yet")
@ -206,12 +217,14 @@ func (c *EEBus) Status() (api.ChargeStatus, error) {
switch currentState {
case communication.EVChargeStateEnumTypeUnknown, communication.EVChargeStateEnumTypeUnplugged: // Unplugged
c.evConnectedTime = time.Now()
c.expectedEnableState = false
return api.StatusA, nil
case communication.EVChargeStateEnumTypeFinished, communication.EVChargeStateEnumTypePaused: // Finished, Paused
return api.StatusB, nil
case communication.EVChargeStateEnumTypeActive: // Active
if isCharging(data.EVData) {
// we might already be enabled and charging due to connection issues
c.expectedEnableState = true
return api.StatusC, nil
}
return api.StatusB, nil
@ -222,29 +235,16 @@ func (c *EEBus) Status() (api.ChargeStatus, error) {
return api.StatusNone, fmt.Errorf("properties unknown result: %s", currentState)
}
// Status implements the api.Charger interface
func (c *EEBus) Status() (api.ChargeStatus, error) {
return c.updateState()
}
// Enabled implements the api.Charger interface
// should return true if the charger allows the EV to draw power
func (c *EEBus) Enabled() (bool, error) {
var res bool
// we might already be enabled and charging due to connection issues
data, err := c.cc.GetData()
if err == nil {
// handle ev being disconnected
if data.EVData.ChargeState != communication.EVChargeStateEnumTypeUnplugged &&
data.EVData.ChargeState != communication.EVChargeStateEnumTypeUnknown {
var status api.ChargeStatus
if status, err = c.Status(); err == nil {
if status == api.StatusB || status == api.StatusC {
res = isCharging(data.EVData)
}
}
}
}
// return the save enable state as we assume enabling/disabling always works
return res, err
_, err := c.updateState()
return c.expectedEnableState, err
}
// Enable implements the api.Charger interface
@ -275,6 +275,8 @@ func (c *EEBus) Enable(enable bool) error {
return api.ErrMustRetry
}
c.expectedEnableState = enable
if !enable {
// Important notes on enabling/disabling!!
// ISO15118 mode: