feat(dispatch): evaluate price automation policies

Author: Miniks040506

services/dispatch-service/src/main/java/io/voltweave/dispatch/access/IntelligenceDispatchClient.java

@@ -83,7 +83,8 @@ public Optional<AutomationPlan> automationPlan(AutomationPolicy policy) {
                             "/internal/v1/vpps/{vppId}/automation-plans", policy.vppId()
                     )
                     .body(new AutomationPlanRequest(
-                            policy.organizationId(), policy.peakImportLimitKw(),
+                            policy.organizationId(), policy.triggerType(),
+                            policy.peakImportLimitKw(), policy.priceThreshold(),
                             policy.maxDispatchPowerKw(), policy.maxDispatchDurationMinutes(),
                             BigDecimal.valueOf(policy.reserveMarginPercent())
                     ))
@@ -143,7 +144,9 @@ public record ReplacementPlan(
 
     private record AutomationPlanRequest(
             UUID organizationId,
+            String triggerType,
             BigDecimal peakImportLimitKw,
+            BigDecimal priceThreshold,
             BigDecimal maxDispatchPowerKw,
             int maxDispatchDurationMinutes,
             BigDecimal reserveMarginPercent

services/dispatch-service/src/main/java/io/voltweave/dispatch/application/AutomationEvaluationJob.java

@@ -31,7 +31,7 @@ public void evaluate() {
         automationService.expireCandidates();
         for (var policy : portfolioClient.activeAutomationPolicies()) {
             try {
-                if (!"PEAK_LIMIT".equals(policy.triggerType())) {
+                if ("MANUAL".equals(policy.triggerType())) {
                     continue;
                 }
                 intelligenceClient.automationPlan(policy)

services/dispatch-service/src/test/java/io/voltweave/dispatch/application/AutomationEvaluationJobTests.java

@@ -0,0 +1,52 @@
+package io.voltweave.dispatch.application;
+
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import java.math.BigDecimal;
+import java.time.Duration;
+import java.time.Instant;
+import java.util.List;
+import java.util.Optional;
+import java.util.UUID;
+
+import org.junit.jupiter.api.Test;
+
+import io.voltweave.dispatch.access.IntelligenceDispatchClient;
+import io.voltweave.dispatch.access.PortfolioAccessClient;
+import io.voltweave.dispatch.application.model.AutomationPlan;
+import io.voltweave.dispatch.application.model.AutomationPolicy;
+
+class AutomationEvaluationJobTests {
+    @Test
+    void evaluatesPricePolicyAndSkipsManualPolicy() {
+        var portfolio = mock(PortfolioAccessClient.class);
+        var intelligence = mock(IntelligenceDispatchClient.class);
+        var automation = mock(AutomationApplicationService.class);
+        var price = policy("PRICE_THRESHOLD");
+        var manual = policy("MANUAL");
+        var plan = new AutomationPlan(
+                Instant.parse("2026-08-13T17:00:00Z"), Duration.ofMinutes(30),
+                UUID.randomUUID(), true
+        );
+        when(portfolio.activeAutomationPolicies()).thenReturn(List.of(price, manual));
+        when(intelligence.automationPlan(price)).thenReturn(Optional.of(plan));
+
+        new AutomationEvaluationJob(portfolio, intelligence, automation).evaluate();
+
+        verify(automation).expireCandidates();
+        verify(automation).createCandidate(price, plan);
+        verify(intelligence, never()).automationPlan(manual);
+    }
+
+    private static AutomationPolicy policy(String trigger) {
+        return new AutomationPolicy(
+                UUID.randomUUID(), UUID.randomUUID(), UUID.randomUUID(), trigger,
+                "AUTO_DISPATCH", "PEAK_LIMIT".equals(trigger) ? BigDecimal.TEN : null,
+                "PRICE_THRESHOLD".equals(trigger) ? new BigDecimal("0.20") : null,
+                10, new BigDecimal("5"), 30, 2
+        );
+    }
+}

services/intelligence-service/src/main/java/io/voltweave/intelligence/optimization/api/controller/InternalAutomationPlanController.java

@@ -28,10 +28,19 @@ public ResponseEntity<AutomationPlanResponse> plan(
             @PathVariable UUID vppId,
             @Valid @RequestBody PlanAutomationRequest request
     ) {
-        return ResponseEntity.of(planningService.peakLimitPlan(
-                request.organizationId(), vppId, request.peakImportLimitKw(),
-                request.maxDispatchPowerKw(), request.maxDispatchDurationMinutes(),
-                request.reserveMarginPercent()
-        ).map(AutomationPlanResponse::from));
+        var plan = switch (request.triggerType()) {
+            case "PEAK_LIMIT" -> planningService.peakLimitPlan(
+                    request.organizationId(), vppId, request.peakImportLimitKw(),
+                    request.maxDispatchPowerKw(), request.maxDispatchDurationMinutes(),
+                    request.reserveMarginPercent()
+            );
+            case "PRICE_THRESHOLD" -> planningService.priceThresholdPlan(
+                    request.organizationId(), vppId, request.priceThreshold(),
+                    request.maxDispatchPowerKw(), request.maxDispatchDurationMinutes(),
+                    request.reserveMarginPercent()
+            );
+            default -> throw new IllegalArgumentException("Unsupported automation trigger");
+        };
+        return ResponseEntity.of(plan.map(AutomationPlanResponse::from));
     }
 }

services/intelligence-service/src/main/java/io/voltweave/intelligence/optimization/api/request/PlanAutomationRequest.java

@@ -8,10 +8,13 @@
 import jakarta.validation.constraints.Max;
 import jakarta.validation.constraints.Min;
 import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.NotBlank;
 
 public record PlanAutomationRequest(
         @NotNull UUID organizationId,
-        @NotNull @DecimalMin(value = "0", inclusive = false) BigDecimal peakImportLimitKw,
+        @NotBlank String triggerType,
+        @DecimalMin(value = "0", inclusive = false) BigDecimal peakImportLimitKw,
+        @DecimalMin(value = "0", inclusive = false) BigDecimal priceThreshold,
         @NotNull @DecimalMin(value = "0", inclusive = false) BigDecimal maxDispatchPowerKw,
         @Min(15) @Max(1440) int maxDispatchDurationMinutes,
         @NotNull @DecimalMin("0") @DecimalMax("100") BigDecimal reserveMarginPercent