[Edge] Evcs.OpenWB: refactor to use MQTT (OpenEMS#3467)

* [Edge] Migrate OpenWB EVCS from HTTP to MQTT

This update transitions the OpenWB EVCS integration from using HTTP API calls to MQTT for communication. The change involves modifying the configuration to use MQTT URI, username, and password instead of IP address and port. It also includes updates to the implementation to subscribe to MQTT topics for receiving data such as power, voltage, and state changes, and to publish commands. This migration improves the reliability and efficiency of the communication with OpenWB devices by leveraging the lightweight MQTT protocol, which is better suited for real-time data exchange in IoT applications.

* Handle energyStartSession initialization during charging

Initialize energyStartSession when charging has already been started.

Author: Sn0w3y

io.openems.edge.evcs.openwb/bnd.bnd

@@ -6,6 +6,7 @@ Bundle-Version: 1.0.0.${tstamp}
 -buildpath: \
 	${buildpath},\
 	io.openems.common,\
+	io.openems.edge.bridge.mqtt,\
 	io.openems.edge.common,\
 	io.openems.edge.evcs.api,\
 	io.openems.edge.meter.api,\

io.openems.edge.evcs.openwb/src/io/openems/edge/evcs/openwb/Config.java

@@ -3,9 +3,11 @@
 import org.osgi.service.metatype.annotations.AttributeDefinition;
 import org.osgi.service.metatype.annotations.ObjectClassDefinition;
 
+import io.openems.edge.meter.api.PhaseRotation;
+
 @ObjectClassDefinition(//
 		name = "EVCS OpenWB", //
-		description = "Implements the evcs component for OpenWB Series2 with internal chargepoints via HTTP API")
+		description = "Implements the EVCS component for OpenWB Series2 with internal chargepoints via MQTT")
 @interface Config {
 
 	@AttributeDefinition(name = "Component-ID", description = "Unique ID of this Component")
@@ -17,15 +19,15 @@
 	@AttributeDefinition(name = "Is enabled?", description = "Is this Component enabled?")
 	boolean enabled() default true;
 
-	@AttributeDefinition(name = "IP-Address", description = "The IP address of the charging station", required = true)
-	String ip();
-
-	@AttributeDefinition(name = "Port", description = "Port of the charging station")
-	int port() default 8443;
+	@AttributeDefinition(name = "MQTT Bridge ID", description = "ID of the MQTT Bridge component (e.g., mqtt0)")
+	String mqttBridgeId() default "mqtt0";
 
-	@AttributeDefinition(name = "Chargepoint", description = "Number of the internal chargepoint")
+	@AttributeDefinition(name = "Chargepoint", description = "Number of the internal chargepoint (duo_num)")
 	ChargePoint chargePoint() default ChargePoint.CP0;
 
+	@AttributeDefinition(name = "Phase rotation", description = "The way in which the phases are physically rotated.")
+	PhaseRotation phaseRotation() default PhaseRotation.L1_L2_L3;
+
 	String webconsole_configurationFactory_nameHint() default "EVCS OpenWB [{id}]";
 
-}
+}

io.openems.edge.evcs.openwb/src/io/openems/edge/evcs/openwb/EvcsOpenWb.java

@@ -1,37 +1,9 @@
 package io.openems.edge.evcs.openwb;
 
-import io.openems.common.channel.Level;
-import io.openems.edge.common.channel.Doc;
+import io.openems.edge.bridge.mqtt.api.MqttComponent;
 import io.openems.edge.common.component.OpenemsComponent;
 import io.openems.edge.evcs.api.Evcs;
 
-public interface EvcsOpenWb extends Evcs, OpenemsComponent {
+public interface EvcsOpenWb extends Evcs, OpenemsComponent, MqttComponent {
 
-	public enum ChannelId implements io.openems.edge.common.channel.ChannelId {
-		/**
-		 * Slave Communication Failed Fault.
-		 *
-		 * <p>
-		 * Indicates a failure in communication with a slave device, which might affect
-		 * system operations.
-		 *
-		 * <ul>
-		 * <li>Interface: ShellyPlug
-		 * <li>Type: State
-		 * </ul>
-		 */
-		SLAVE_COMMUNICATION_FAILED(Doc.of(Level.FAULT)//
-				.text("Communication with slave device failed."));
-
-		private final Doc doc;
-
-		private ChannelId(Doc doc) {
-			this.doc = doc;
-		}
-
-		@Override
-		public Doc doc() {
-			return this.doc;
-		}
-	}
 }