Update InitializeEdgesWorker.java

io.openems.backend.metadata.odoo/src/io/openems/backend/metadata/odoo/postgres/InitializeEdgesWorker.java

@@ -5,6 +5,8 @@
 import java.sql.SQLException;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -21,6 +23,8 @@ public class InitializeEdgesWorker {
 	protected final PostgresHandler parent;
 	private final HikariDataSource dataSource;
 	private final Runnable onFinished;
+	private final ScheduledExecutorService scheduledExecutor = Executors.newScheduledThreadPool(1);
+	private boolean isMarkAllEdgesAsOfflineCalled = false;
 
 	/**
 	 * Executor for subscriptions task.
@@ -39,24 +43,42 @@ public InitializeEdgesWorker(PostgresHandler parent, HikariDataSource dataSource
 	public synchronized void start() {
 		this.executor.execute(() -> {
 			try (var con = this.dataSource.getConnection()) {
-				this.parent.logInfo(this.log, "Caching Edges from Postgres [started]");
-				this.markAllEdgesAsOffline(con);
-				this.readAllEdgesFromPostgres(con);
-				this.parent.logInfo(this.log, "Caching Edges from Postgres [finished]");
+				// Erste Ausführung sofort
+				runCachingEdgesTask(con);
+
+				// Planen der die periodische Ausführung
+				scheduledExecutor.scheduleAtFixedRate(() -> {
+					try (var newCon = this.dataSource.getConnection()) {
+						runCachingEdgesTask(newCon);
+					} catch (SQLException e) {
+						logError("Fehler beim erneuten Verbinden mit Postgres.", e);
+					}
+				}, 20, 20, TimeUnit.MINUTES);
 			} catch (SQLException e) {
-				this.parent.logWarn(this.log, "Caching Edges from Postgres [canceled]");
-				this.logError("Unable to connect do dataSource. ", e);
+				logError("Unable to connect do dataSource. ", e);
 			}
 			this.onFinished.run();
 		});
 	}
 
+	private void runCachingEdgesTask(Connection con) {
+		this.parent.logInfo(this.log, "Caching Edges from Postgres [started]");
+		// Überprüfen, ob markAllEdgesAsOffline bereits aufgerufen wurde
+		if (!isMarkAllEdgesAsOfflineCalled) {
+			this.markAllEdgesAsOffline(con);
+			isMarkAllEdgesAsOfflineCalled = true;
+		}
+		this.readAllEdgesFromPostgres(con);
+		this.parent.logInfo(this.log, "Caching Edges from Postgres [finished]");
+	}
+
 	/**
 	 * Stops the {@link InitializeEdgesWorker}.
 	 */
 	public synchronized void stop() {
 		// Shutdown executor
 		ThreadPoolUtils.shutdownAndAwaitTermination(this.executor, 5);
+		ThreadPoolUtils.shutdownAndAwaitTermination(this.scheduledExecutor, 5);
 	}
 
 	private void markAllEdgesAsOffline(Connection con) {