Makes scheduled entries directly executable from overview page

src/main/java/sirius/biz/jobs/scheduler/SchedulerController.java

@@ -11,13 +11,19 @@
 import sirius.biz.jobs.JobConfigData;
 import sirius.biz.jobs.JobFactory;
 import sirius.biz.jobs.Jobs;
+import sirius.biz.process.Process;
+import sirius.biz.process.Processes;
 import sirius.biz.web.BasePageHelper;
 import sirius.biz.web.BizController;
 import sirius.biz.web.TenantAware;
+import sirius.db.es.ElasticQuery;
 import sirius.db.mixing.BaseEntity;
 import sirius.db.mixing.query.QueryField;
 import sirius.kernel.commons.Strings;
+import sirius.kernel.di.PartCollection;
 import sirius.kernel.di.std.Part;
+import sirius.kernel.di.std.Parts;
+import sirius.kernel.health.Exceptions;
 import sirius.kernel.nls.NLS;
 import sirius.web.controller.AutocompleteHelper;
 import sirius.web.controller.Routed;
@@ -26,6 +32,8 @@
 import sirius.web.security.UserContext;
 import sirius.web.security.UserInfo;
 
+import java.time.LocalDateTime;
+
 /**
  * Provides a base class to create the management UI for the job scheduler.
  * <p>
@@ -41,6 +49,15 @@ public abstract class SchedulerController<J extends BaseEntity<?> & SchedulerEnt
     @Part
     private Jobs jobs;
 
+    @Part
+    private Processes processes;
+
+    @Parts(SchedulerEntryProvider.class)
+    private PartCollection<SchedulerEntryProvider<J>> providers;
+
+    @Part
+    private ScheduledEntryExecution entryExecution;
+
     /**
      * Returns the entity class being used by this controller.
      *
@@ -103,6 +120,53 @@ public void schedulerEntry(WebContext webContext, String entryId) {
         }
     }
 
+    /**
+     * Executes the given scheduler entry immediately and redirects to the process detail view.
+     *
+     * @param webContext the current request
+     * @param entryId    the id of the entry to display or <tt>new</tt> to create a new one
+     */
+    @Permission(PERMISSION_MANAGE_SCHEDULER)
+    @Routed("/jobs/scheduler/execute-entry/:1")
+    public void executeSchedulerEntry(WebContext webContext, String entryId) {
+        J entry = findForTenant(getEntryType(), entryId);
+
+        if (entry.isNew()) {
+            schedulerEntries(webContext);
+            return;
+        }
+
+        executeInBelongingProvider(entry);
+
+        webContext.respondWith().redirectToGet("/ps/" + fetchLatestProcess(entry).getIdAsString());
+    }
+
+    private Process fetchLatestProcess(J entry) {
+        ElasticQuery<Process> query = processes.queryProcessesForCurrentUser();
+        query.eqIgnoreNull(Process.REFERENCES, entry.getUniqueName());
+        query.orderDesc(Process.STARTED);
+        return query.first()
+                    .orElseThrow(() -> Exceptions.createHandled()
+                                                 .withNLSKey("SchedulerController.noProcessFound")
+                                                 .handle());
+    }
+
+    private void executeInBelongingProvider(J entry) {
+        for (SchedulerEntryProvider<J> provider : providers) {
+            J entryFromProvider = provider.fetchFullInformation(entry);
+            if (entryBelongsToProvider(entry, entryFromProvider)) {
+                entryExecution.executeJob(provider, entryFromProvider, LocalDateTime.now());
+                return;
+            }
+        }
+    }
+
+    private static <J extends BaseEntity<?> & SchedulerEntry & TenantAware> boolean entryBelongsToProvider(J entry,
+                                                                                                           J providersEntry) {
+        // The belonging provided must have refreshed data, so the object identity is different.
+        return System.identityHashCode(providersEntry) != System.identityHashCode(entry);
+    }
+
     protected void loadUser(WebContext webContext, J entry) {
         UserInfo user = UserContext.get()
                                    .getUserManager()

src/main/resources/biz_de.properties

@@ -929,6 +929,7 @@ SchedulerEntry.invalidPatternInField = Ungültiger Wert im Feld ${field}: ${msg}
 SchedulerEntry.lastExecution = Letzte Ausführung
 SchedulerEntry.minute = Minute
 SchedulerEntry.month = Monat
+SchedulerEntry.executeNow = Jetzt ausführen
 SchedulerEntry.numberOfExecutions = Anzahl Ausführungen
 SchedulerEntry.performedExecutions = Ausführungen
 SchedulerEntry.plural = Geplante Ausführungen

src/main/resources/default/templates/biz/jobs/scheduler/entries.html.pasta

@@ -34,6 +34,10 @@
                                 url="@apply('/ps?reference=%s&reference-label=%s', entry.getUniqueName(), urlEncode(entry.toString()))"
                                 icon="fa-solid fa-list"
                                 labelKey="SchedulerEntry.performedExecutions"/>
+                        <t:dropdownItem
+                                url="@apply('/jobs/scheduler/execute-entry/%s', entry.getIdAsString())"
+                                icon="fa-solid fa-play"
+                                labelKey="SchedulerEntry.executeNow"/>
                         <t:dropdownDeleteItem
                                 url="@apply('/jobs/scheduler/entry/%s/delete', entry.getIdAsString())"/>
                     </i:block>