Skip to content

force_soc_update: keinen Retry-Loop bei dauerhaft veraltetem EV-SoC #4036

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
LKuemmel merged 2 commits into from
Oct 15, 2026
Merged

force_soc_update: keinen Retry-Loop bei dauerhaft veraltetem EV-SoC #4036

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
a0dffba
force_soc_update: keinen Retry-Loop bei dauerhaft veraltetem EV-SoC
seaspotter Sep 29, 2026
f3025e7
force_soc_update: setdata.py-Handling für neue Topics ergänzen, doppe…
seaspotter Oct 14, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 12 additions & 4 deletions packages/control/chargepoint/chargepoint.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -731,13 +731,18 @@ def update(self, ev_list: Dict[str, Ev]) -> None:
if self.data.get.plug_state and self.data.set.plug_state_prev is False:
self.data.control_parameter.timestamp_chargemode_changed = create_timestamp()
# SoC nach Anstecken aktualisieren
soc_update_target_ev = vehicle if vehicle != -1 else self.data.config.ev
if ((self.data.get.plug_state and self.data.set.plug_state_prev is False) or
(self.data.get.plug_state is False and self.data.set.plug_state_prev) or
(self.data.get.soc_timestamp and self.data.set.charging_ev_data.data.get.soc_timestamp and
self.data.get.soc_timestamp > self.data.set.charging_ev_data.data.get.soc_timestamp)):
Pub().pub(
f"openWB/set/vehicle/{vehicle if vehicle != -1 else self.data.config.ev}/get/force_soc_update",
True)
self.data.get.soc_timestamp > self.data.set.charging_ev_data.data.get.soc_timestamp and
# nicht jeden Zyklus erneut anstoßen, wenn der EV-SoC dauerhaft veraltet bleibt
# (zB API-Fehler); nur bei neuem CP-SoC oder EV-Wechsel am LP erneut auslösen
(self.data.get.soc_timestamp != self.data.set.soc_timestamp_force_update_prev or
soc_update_target_ev != self.data.set.soc_timestamp_force_update_prev_ev))):
Comment thread
seaspotter marked this conversation as resolved.
Pub().pub(f"openWB/set/vehicle/{soc_update_target_ev}/get/force_soc_update", True)
self.data.set.soc_timestamp_force_update_prev = self.data.get.soc_timestamp
self.data.set.soc_timestamp_force_update_prev_ev = soc_update_target_ev
log.debug("SoC nach Anstecken")
self.set_state_and_log(message)
except Exception:
Expand Down Expand Up @@ -766,6 +771,9 @@ def _get_charging_ev(self, vehicle: int, ev_list: Dict[str, Ev]) -> Ev:
self.update_charge_template(charging_ev.charge_template)
if self.data.config.ev != vehicle:
Pub().pub(f"openWB/set/vehicle/{charging_ev.num}/get/force_soc_update", True)
# verhindert doppeltes Pub in der "SoC nach Anstecken"-Prüfung im selben update()-Zyklus
self.data.set.soc_timestamp_force_update_prev = self.data.get.soc_timestamp
self.data.set.soc_timestamp_force_update_prev_ev = vehicle
log.debug("SoC nach EV-Wechsel")
self.data.config.ev = vehicle
self.data.set.charging_ev_data = charging_ev
Expand Down
7 changes: 7 additions & 0 deletions packages/control/chargepoint/chargepoint_data.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -174,6 +174,13 @@ class Set:
charging_ev_data: Ev = field(default_factory=ev_factory)
ocpp_transaction_id: Optional[int] = field(default=None, metadata={"topic": "set/ocpp_transaction_id"})
charge_state_prev: bool = field(default=False, metadata={"topic": "set/charge_state_prev"})
# letzter CP-SoC-Timestamp, für den bereits ein force_soc_update ausgelöst wurde, und das zugehörige EV,
# um bei dauerhaft veraltetem EV-SoC (zB API-Fehler) nicht jeden Zyklus erneut ein Update anzustoßen,
# aber bei einem EV-Wechsel am selben Ladepunkt trotzdem einmal neu auszulösen
soc_timestamp_force_update_prev: Optional[int] = field(
default=None, metadata={"topic": "set/soc_timestamp_force_update_prev"})
soc_timestamp_force_update_prev_ev: Optional[int] = field(
default=None, metadata={"topic": "set/soc_timestamp_force_update_prev_ev"})
Comment thread
seaspotter marked this conversation as resolved.


@dataclass
Expand Down
2 changes: 2 additions & 0 deletions packages/helpermodules/setdata.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -505,6 +505,8 @@ def process_chargepoint_topic(self, msg: mqtt.MQTTMessage):
self._validate_value(msg, float)
elif "/set/ocpp_transaction_id" in msg.topic:
self._validate_value(msg, int)
elif "/set/soc_timestamp_force_update_prev" in msg.topic:
self._validate_value(msg, int)
elif "/set/log" in msg.topic:
self._validate_value(msg, "json")
elif "/set/ev_prev" in msg.topic:
Expand Down
6 changes: 4 additions & 2 deletions packages/modules/common/store/_chargepoint.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,8 +37,10 @@ def update(self):
if self.state.rfid_timestamp is not None:
pub_to_broker("openWB/set/chargepoint/" + str(self.num) + "/get/rfid_timestamp", self.state.rfid_timestamp)
pub_to_broker("openWB/set/chargepoint/" + str(self.num) + "/get/serial_number", self.state.serial_number)
pub_to_broker("openWB/set/chargepoint/" + str(self.num) + "/get/soc", self.state.soc)
pub_to_broker("openWB/set/chargepoint/" + str(self.num) + "/get/soc_timestamp", self.state.soc_timestamp)
if self.state.soc is not None:
pub_to_broker("openWB/set/chargepoint/" + str(self.num) + "/get/soc", self.state.soc)
if self.state.soc_timestamp is not None:
pub_to_broker("openWB/set/chargepoint/" + str(self.num) + "/get/soc_timestamp", self.state.soc_timestamp)
pub_to_broker("openWB/set/chargepoint/" + str(self.num) + "/get/evse_current", self.state.evse_current)
pub_to_broker("openWB/set/chargepoint/" + str(self.num) + "/get/vehicle_id", self.state.vehicle_id)
pub_to_broker("openWB/set/chargepoint/" + str(self.num) + "/get/max_evse_current", self.state.max_evse_current)
Expand Down
Loading