feat(jmanus):Extended acquisition agent implementation

Author: 厚正

spring-ai-alibaba-jmanus/src/main/java/com/alibaba/cloud/ai/example/manus/dynamic/agent/service/DynamicAgentLoader.java

@@ -20,6 +20,7 @@
 import java.util.Objects;
 
 import com.alibaba.cloud.ai.example.manus.dynamic.prompt.service.PromptService;
+import com.alibaba.cloud.ai.example.manus.planning.model.vo.ExecutionContext;
 import org.springframework.ai.model.tool.ToolCallingManager;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Lazy;
@@ -88,4 +89,8 @@ public List<DynamicAgentEntity> getAllAgents() {
 			.toList();
 	}
 
+	@Override
+	public List<DynamicAgentEntity> getAgents(ExecutionContext context) {
+		return IDynamicAgentLoader.super.getAgents(context);
+	}
 }

spring-ai-alibaba-jmanus/src/main/java/com/alibaba/cloud/ai/example/manus/dynamic/agent/service/IDynamicAgentLoader.java

@@ -20,6 +20,7 @@
 
 import com.alibaba.cloud.ai.example.manus.dynamic.agent.DynamicAgent;
 import com.alibaba.cloud.ai.example.manus.dynamic.agent.entity.DynamicAgentEntity;
+import com.alibaba.cloud.ai.example.manus.planning.model.vo.ExecutionContext;
 
 /**
  * Dynamic Agent loader interface, providing Agent loading function
@@ -40,4 +41,8 @@ public interface IDynamicAgentLoader {
 	 */
 	List<DynamicAgentEntity> getAllAgents();
 
+	default  List<DynamicAgentEntity> getAgents(ExecutionContext context){
+		return getAllAgents();
+	}
+
 }

spring-ai-alibaba-jmanus/src/main/java/com/alibaba/cloud/ai/example/manus/planning/PlanningFactory.java

@@ -22,6 +22,7 @@
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 
+import com.alibaba.cloud.ai.example.manus.planning.model.vo.ExecutionContext;
 import org.apache.hc.client5.http.classic.HttpClient;
 import org.apache.hc.client5.http.config.RequestConfig;
 import org.apache.hc.client5.http.impl.classic.HttpClients;
@@ -173,10 +174,10 @@ public PlanningFactory(ChromeDriverService chromeDriverService, PlanExecutionRec
 	}
 
 	// Use the enhanced PlanningCoordinator with dynamic executor selection
-	public PlanningCoordinator createPlanningCoordinator(String planId) {
+	public PlanningCoordinator createPlanningCoordinator(ExecutionContext context) {
 
 		// Add all dynamic agents from the database
-		List<DynamicAgentEntity> agentEntities = dynamicAgentLoader.getAllAgents();
+		List<DynamicAgentEntity> agentEntities = dynamicAgentLoader.getAgents(context);
 
 		PlanningToolInterface planningTool = new PlanningTool();
 

spring-ai-alibaba-jmanus/src/main/java/com/alibaba/cloud/ai/example/manus/planning/controller/ManusController.java

@@ -98,7 +98,7 @@ public ResponseEntity<Map<String, Object>> executeQuery(@RequestBody Map<String,
 		context.setNeedSummary(true);
 
 		// Get or create planning flow
-		PlanningCoordinator planningFlow = planningFactory.createPlanningCoordinator(planId);
+		PlanningCoordinator planningFlow = planningFactory.createPlanningCoordinator(context);
 
 		// Asynchronous execution of task
 		CompletableFuture.supplyAsync(() -> {