Merge remote-tracking branch 'origin/dev' into dev

- 在 FlowTaskRuntimeEntry 中添加事务注解支持
- 为 FlowTaskRuntimeService 接口添加方法间隔
- 在 TeFlowController 中引入任务实例ID列表管理
- 新增 demo 接口用于任务执行和实例清理
- 实现任务实例的自动停止和清理机制
- 集成 flowControlService 的 stop 功能用于流程控制

cmvr-iot-admin/src/main/java/com/cmvr/web/controller/test/TeFlowController.java

@@ -1,5 +1,6 @@
 package com.cmvr.web.controller.test;
 
+import com.cmvr.common.annotation.Anonymous;
 import com.cmvr.common.core.controller.BaseController;
 import com.cmvr.common.core.domain.AjaxResult;
 import com.cmvr.test.flow.context.TaskContextManager;
@@ -26,6 +27,8 @@ import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.validation.Valid;
+import java.util.ArrayList;
+import java.util.List;
 
 @Api(tags = "测试--流程服务")
 @RestController
@@ -40,15 +43,34 @@ public class TeFlowController extends BaseController {
     private final FlowControlService flowControlService;
     private final FlowActionExecutorService flowActionExecutorService;
     private final TiTouchOperateService tiTouchOperateService;
-
+    private final List<String> taskInstIdList = new ArrayList<>();
     @ApiOperation("流程发布")
     @PostMapping("/publish")
     public AjaxResult publish(@RequestBody TeDetectionItem detectionItem) {
         return toAjax(teDetectionItemService.publish(detectionItem.getId()));
     }
 
+
+    @ApiOperation("任务执行入口")
+    @PostMapping("/demo")
+    @Anonymous
+    public AjaxResult demo(@Valid @RequestBody TeTaskExecuteNormalVO taskExecuteNormalVO) {
+        if (taskInstIdList.size() > 0) {
+            try {
+                taskInstIdList.forEach(flowControlService::stop);
+            } catch (Exception e) {
+                // 忽略
+            }
+            taskInstIdList.clear();
+        }
+        String insId = flowTaskRuntimeService.executeTask(taskExecuteNormalVO);
+        taskInstIdList.add(insId);
+        return AjaxResult.success();
+    }
+
     @ApiOperation("任务执行入口")
     @PostMapping("/execute")
+    @Anonymous
     public AjaxResult execute(@Valid @RequestBody TeTaskExecuteNormalVO taskExecuteNormalVO) {
         return AjaxResult.success(flowTaskRuntimeService.executeTask(taskExecuteNormalVO));
     }

cmvr-iot-admin/src/main/resources/application-prod.yml

@@ -92,7 +92,7 @@ spring:
 
 # Minio配置
 minio:
-  url: http://mini:9000
+  url: http://minio:9000
   accessKey: AKICMVR
   secretKey: wJalrXUtnFEMI
   bucketName: cmvr-iot
@@ -118,8 +118,8 @@ api:
   # ActionEnum 的枚举作为 key
   agents:
     INTENT_RECOGNITION: # 意图识别
-      app-id: d3c98sp0gdon0fcf6l00
+      app-id: d5dn5ibp9adhq1b34lig
-      app-key: d3c98vp0gdon0fcf6n20
+      app-key: d6j5bcellh49on5tasvg
     TI_TOUCH_COORDINATES: # 获取触控二维坐标
       app-id: d1ebtabnjkflk4gmhikg
       app-key: d5thge2cktmipk78h82g

cmvr-iot-api/cmvr-iot-edge/cmvr-iot-grpc-client/src/main/java/com/cmvr/edge/client/service/impl/EdgeHlcServiceImpl.java

@@ -3,6 +3,7 @@ package com.cmvr.edge.client.service.impl;
 import cmvr.api.HlcCommand;
 import cmvr.api.HlcServiceGrpc;
 import com.alibaba.fastjson2.JSON;
+import com.cmvr.common.exception.GlobalException;
 import com.cmvr.edge.client.manage.GrpcServiceManager;
 import com.cmvr.edge.client.model.hlc.EdgeTouchVO;
 import com.cmvr.edge.client.service.EdgeHlcService;
@@ -85,6 +86,9 @@ public class EdgeHlcServiceImpl implements EdgeHlcService {
 
     @Override
     public String touch(EdgeTouchVO edgeTouchVO) {
+        if (edgeTouchVO.getX() == edgeTouchVO.getY() && edgeTouchVO.getX() == 0) {
+            throw new GlobalException("触控坐标不能为0");
+        }
         HlcServiceGrpc.HlcServiceBlockingStub stub = grpcServiceManager.getGrpcClient(edgeTouchVO.getTerminalId(), HlcServiceGrpc.HlcServiceBlockingStub.class);
         HlcCommand.Touch.Request request = HlcCommand.Touch.Request.newBuilder()
                 .setHeader(EdgeCommonUtil.buildRequest(edgeTouchVO.getDeviceId()))

cmvr-iot-api/cmvr-iot-llm/src/main/java/com/cmvr/llm/service/LLMAiAgentPlatformService.java

@@ -3,5 +3,5 @@ package com.cmvr.llm.service;
 import com.alibaba.fastjson2.JSONObject;
 
 public interface LLMAiAgentPlatformService {
-    JSONObject query(String action, String text, String apiKey);
+    JSONObject query(String action, String text, String apiKey, Boolean invokeTts, JSONObject config);
 }

cmvr-iot-api/cmvr-iot-llm/src/main/java/com/cmvr/llm/service/WorkflowInvokeServiceCopy.java

@@ -90,7 +90,9 @@ public class WorkflowInvokeServiceCopy {
                     appKey,  // apiKey (header用)
                     appId,  // apiId (body的AppKey)
                     "user_123",               // userId
-                    body
+                    body,
+                    false,
+                    null
             );
             System.out.println( result);
             System.out.println("总耗时：" + (System.currentTimeMillis() - startTime));

cmvr-iot-api/cmvr-iot-llm/src/main/java/com/cmvr/llm/service/impl/LLMAiAgentPlatformServiceImpl.java

@@ -14,7 +14,7 @@ import java.util.Map;
 public class LLMAiAgentPlatformServiceImpl  implements LLMAiAgentPlatformService {
     private final LlmChatService llmChatService;
     @Override
-    public JSONObject query(String action, String text, String apiKey) {
+    public JSONObject query(String action, String text, String apiKey, Boolean invokeTts, JSONObject config) {
         Map<String, Object> body = new HashMap<>();
         body.put("Query", text);
         long startTime = System.currentTimeMillis();
@@ -24,7 +24,9 @@ public class LLMAiAgentPlatformServiceImpl  implements LLMAiAgentPlatformService
                     apiKey,  // apiKey (header用)
                     apiKey,  // apiId (body的AppKey)
                     "user_123",               // userId
-                    body
+                    body,
+                    invokeTts,
+                    config
             );
             System.out.println( result);
             System.out.println("总耗时：" + (System.currentTimeMillis() - startTime));

cmvr-iot-api/cmvr-iot-llm/src/main/java/com/cmvr/llm/service/impl/LLMIntentRecognitionServiceImpl.java

@@ -36,7 +36,9 @@ public class LLMIntentRecognitionServiceImpl implements LLMIntentRecognitionServ
                     acg.getAppKey(),  // apiKey (header用)
                     acg.getAppId(),  // apiId (body的AppKey)
                     "user_123",               // userId
-                    body
+                    body,
+                    false,
+                    null
             );
             System.out.println( result);
             System.out.println("总耗时：" + (System.currentTimeMillis() - startTime));

cmvr-iot-api/cmvr-iot-llm/src/main/java/com/cmvr/llm/util/LlmChatService.java

@@ -1,7 +1,11 @@
 package com.cmvr.llm.util;
 
+import com.alibaba.fastjson2.JSONObject;
+import com.cmvr.llm.service.LLMAiTtsService;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import lombok.extern.slf4j.Slf4j;
 import okhttp3.*;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.PreDestroy;
@@ -10,17 +14,18 @@ import java.io.IOException;
 import java.io.InputStreamReader;
 import java.nio.charset.StandardCharsets;
 import java.util.*;
-import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.*;
-import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.atomic.AtomicBoolean;
-import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicReference;
 
 /**
  * LLM聊天服务 - 严格保持原接口参数
  */
+@Slf4j
 @Service
 public class LlmChatService {
-
+    @Autowired
+    private LLMAiTtsService llmAiTtsService;
     private static final String DEFAULT_BASE_URL = "https://aiagentplatform.cmft.com/api/proxy/api/v1";
     private static final MediaType JSON = MediaType.parse("application/json; charset=utf-8");
     private static final ObjectMapper objectMapper = new ObjectMapper();
@@ -48,7 +53,7 @@ public class LlmChatService {
      * @param body    请求体，必须包含Query字段，可选Name等
      * @return 完整AI回复字符串
      */
-    public String chat(String apiKey, String apiId, String userId, Map<String, Object> body) throws IOException {
+    public String chat(String apiKey, String apiId, String userId, Map<String, Object> body, boolean playTts, JSONObject ttsConfig) throws IOException {
         String cacheKey = apiKey + "|" + apiId + "|" + userId;
 
         // 获取或创建会话（严格保持原createConversation逻辑）
@@ -76,7 +81,7 @@ public class LlmChatService {
         }
 
         // 执行流式请求并同步返回完整结果
-        return executeSseRequestSync(apiKey, requestBody);
+        return executeSseRequestSync(apiKey, requestBody, playTts, ttsConfig);
     }
 
     /**
@@ -122,10 +127,13 @@ public class LlmChatService {
         }
     }
 
+
+    // 句子结束符号
+    static final String SENTENCE_END = "?!。？！\n";
     /**
      * 执行SSE请求 - 完全保持原executeSseRequest逻辑，改为同步返回
      */
-    private String executeSseRequestSync(String apiKey, Map<String, Object> requestBody) throws IOException {
+    private String executeSseRequestSync(String apiKey, Map<String, Object> requestBody, boolean playTts, JSONObject ttsConfig) throws IOException {
         String jsonBody = objectMapper.writeValueAsString(requestBody);
 
         Request request = new Request.Builder()
@@ -137,18 +145,49 @@ public class LlmChatService {
                 .build();
 
         StringBuilder fullContent = new StringBuilder();
-        CountDownLatch latch = new CountDownLatch(1);
+        CountDownLatch mainLatch  = new CountDownLatch(1);
         AtomicReference<Throwable> errorRef = new AtomicReference<>();
         AtomicReference<String> finalMessageIdRef = new AtomicReference<>("");
 
+        // ====================== 核心控制 ======================
+
+        // 接收缓存：永远不阻塞
+        StringBuilder receiveBuffer = new StringBuilder();
+        // 单线程串行执行：保证上一句处理完才处理下一句
+        ExecutorService sentenceExecutor = Executors.newSingleThreadExecutor();
+        // 标记流是否已经结束
+        AtomicBoolean streamFinished = new AtomicBoolean(false);
+        final AtomicBoolean interrupted = new AtomicBoolean(false); // 中断标记
         Call call = httpClient.newCall(request);
+        Runnable interruptTask = () -> {
+            interrupted.set(true);
+            call.cancel(); // 真正关闭SSE连接 【关键】
+            streamFinished.set(true);
+            sentenceExecutor.shutdownNow();
+            mainLatch.countDown();
+        };
+
+
 
         // 使用异步调用但阻塞等待结果
         call.enqueue(new Callback() {
+
+            /**
+             * 等待所有句子处理完再结束
+             */
+            private void shutdownAndWait1() {
+                try {
+                    sentenceExecutor.shutdown();
+                    sentenceExecutor.awaitTermination(10, TimeUnit.MINUTES);
+                } catch (InterruptedException ignored) {}
+                mainLatch.countDown();
+            }
+
             @Override
             public void onFailure(Call call, IOException e) {
                 errorRef.set(e);
-                latch.countDown();
+                streamFinished.set(true);
+                shutdownAndWait1();
             }
 
             @Override
@@ -156,7 +195,8 @@ public class LlmChatService {
                 if (!response.isSuccessful()) {
                     String errorBody = response.body() != null ? response.body().string() : "无错误信息";
                     errorRef.set(new IOException("SSE请求失败: " + response.code() + " - " + errorBody));
-                    latch.countDown();
+                    streamFinished.set(true);
+                    shutdownAndWait1();
                     return;
                 }
 
@@ -168,7 +208,7 @@ public class LlmChatService {
                         new InputStreamReader(response.body().byteStream(), StandardCharsets.UTF_8))) {
 
                     String line;
-                    while ((line = reader.readLine()) != null) {
+                    while (!interrupted.get() && (line = reader.readLine()) != null) {
                         if (line.isEmpty()) {
                             currentEvent = "";
                             continue;
@@ -190,8 +230,9 @@ public class LlmChatService {
                             if ("[DONE]".equals(data)) {
                                 fullContent.append(localContent);
                                 finalMessageIdRef.set(finalMessageId);
-                                latch.countDown();
+                                streamFinished.set(true);
-                                return;
+                                processBufferIfNeed();
+                                break;
                             }
 
                             try {
@@ -208,15 +249,18 @@ public class LlmChatService {
                                     String answer = extractString(jsonData, "answer", "content", "chunk", "text");
                                     if (!answer.isEmpty()) {
                                         localContent.append(answer);
+                                        receiveBuffer.append(answer);
+                                        processBufferIfNeed();
                                     }
                                 } else if ("message_start".equals(event)) {
-                                    System.out.println("消息开始，ID: " + finalMessageId);
+                                    log.info("消息开始，ID: " + finalMessageId);
                                 } else if ("message_output_start".equals(event)) {
-                                    System.out.println("输出开始");
+                                    log.info("输出开始");
                                 } else if ("message_end".equals(event) || "end".equals(event)) {
                                     fullContent.append(localContent);
                                     finalMessageIdRef.set(finalMessageId);
-                                    latch.countDown();
+                                    streamFinished.set(true);
+                                    processBufferIfNeed();
                                     return;
                                 }
 
@@ -229,22 +273,77 @@ public class LlmChatService {
                     // 流正常结束
                     fullContent.append(localContent);
                     finalMessageIdRef.set(finalMessageId);
-                    latch.countDown();
 
                 } catch (IOException e) {
                     errorRef.set(e);
-                    latch.countDown();
+                    streamFinished.set(true);
+                } finally {
+                    processBufferIfNeed();
+                    shutdownAndWait1();
                 }
             }
+
+            /**
+             * 核心：提取完整句子 + 异步串行处理
+             */
+            private void processBufferIfNeed() {
+                if (interrupted.get()) return;
+                if (!true) return;
+                if (!playTts) return;
+
+                sentenceExecutor.submit(() -> {
+                    while (true) {
+                        String buffer = receiveBuffer.toString();
+                        // 寻找最后一个句子结束符
+                        int lastSplit = -1;
+                        for (int i = 0; i < buffer.length(); i++) {
+                            if (SENTENCE_END.contains(String.valueOf(buffer.charAt(i)))) {
+                                lastSplit = i;
+                            }
+                        }
+
+                        // 有完整句子 或 流已结束
+                        if (lastSplit >= 0 || streamFinished.get()) {
+                            String sentence;
+                            if (lastSplit >= 0) {
+                                // 截取完整句子
+                                sentence = buffer.substring(0, lastSplit + 1).trim();
+                                // 保留剩余内容
+                                String remain = buffer.substring(lastSplit + 1).trim();
+                                receiveBuffer.setLength(0);
+                                receiveBuffer.append(remain);
+                            } else {
+                                // 流结束，直接处理剩余
+                                sentence = buffer.trim();
+                                receiveBuffer.setLength(0);
+                            }
+
+                            if (!sentence.isEmpty()) {
+                                if (interrupted.get()) return;
+                                yourAsyncMethod(sentence, ttsConfig);
+                            }
+
+                            // 处理完继续循环，看是否还有新句子
+                            if (streamFinished.get() && receiveBuffer.length() == 0) {
+                                break;
+                            }
+                        } else {
+                            // 无完整句子，退出
+                            break;
+                        }
+                    }
+                });
+            }
         });
 
         // 等待流式传输完成
         try {
-            boolean completed = latch.await(120, TimeUnit.SECONDS);
+            boolean completed = mainLatch.await(120, TimeUnit.SECONDS);
             if (!completed) {
                 throw new IOException("请求超时");
             }
         } catch (InterruptedException e) {
+            interruptTask.run(); // 被中断时，立即停止SSE
             Thread.currentThread().interrupt();
             throw new IOException("请求被中断", e);
         }
@@ -260,6 +359,15 @@ public class LlmChatService {
         return fullContent.toString();
     }
 
+    private void yourAsyncMethod(String sentence, JSONObject ttsConfig) {
+        try {
+            log.info("正在处理句子: " + sentence);
+            llmAiTtsService.play(ttsConfig.getString("url"), sentence, ttsConfig.getString("voice"), ttsConfig.getString("speed"), ttsConfig.getString("volume"));
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
     /**
      * 完全保持原extractString方法
      */

cmvr-iot-framework/src/main/java/com/cmvr/framework/config/SecurityConfig.java

@@ -115,7 +115,7 @@ public class SecurityConfig
                     // 静态资源，可匿名访问
                     .antMatchers(HttpMethod.GET, "/", "/*.html", "/**/*.html", "/**/*.css", "/**/*.js", "/profile/**").permitAll()
                     .antMatchers("/system/file/upload","/evaluation/callback","/flow/**","/flowise/**","/kws/**","/ws/**","/api/grpc/**","/show/**",
-                            "/node-red/**","/swagger-ui.html", "/swagger-resources/**", "/webjars/**", "/*/api-docs", "/druid/**", "/ti/**").permitAll()
+                            "/node-red/**","/swagger-ui.html", "/swagger-resources/**", "/webjars/**", "/*/api-docs", "/druid/**", "/ti/**", "/flow/execute").permitAll()
                     // 除上面外的所有请求全部需要鉴权认证
                     .anyRequest().authenticated();
             })

cmvr-iot-framework/src/main/java/com/cmvr/framework/mybatisPlus/MyMetaObjectHandler.java

@@ -24,10 +24,17 @@ public class MyMetaObjectHandler implements MetaObjectHandler {
      */
     @Override
     public void insertFill(MetaObject metaObject) {
+        // 获取用户名（异常时给默认值 anonymous）
+        String username;
+        try {
+            username = SecurityUtils.getUsername();
+        } catch (Exception e) {
+            username = "anonymous"; // 匿名接口默认值
+        }
         // 起始版本 3.3.0(推荐使用)
-        this.setFieldValByName(CREATE_BY, SecurityUtils.getUsername(), metaObject);
+        this.setFieldValByName(CREATE_BY, username, metaObject);
         this.setFieldValByName(CREATE_TIME, formatDate(metaObject.getSetterType(CREATE_TIME)), metaObject);
-        this.setFieldValByName(UPDATE_BY, SecurityUtils.getUsername(), metaObject);
+        this.setFieldValByName(UPDATE_BY, username, metaObject);
         this.setFieldValByName(UPDATE_TIME, formatDate(metaObject.getSetterType(CREATE_TIME)), metaObject);
         this.setFieldValByName(DELETED, "0", metaObject);
 //        this.setFieldValByName(STATUS, "1", metaObject);
@@ -41,7 +48,14 @@ public class MyMetaObjectHandler implements MetaObjectHandler {
      */
     @Override
     public void updateFill(MetaObject metaObject) {
-        this.setFieldValByName(UPDATE_BY, SecurityUtils.getUsername(), metaObject);
+        // 获取用户名（异常时给默认值 anonymous）
+        String username;
+        try {
+            username = SecurityUtils.getUsername();
+        } catch (Exception e) {
+            username = "anonymous"; // 匿名接口默认值
+        }
+        this.setFieldValByName(UPDATE_BY, username, metaObject);
         this.setFieldValByName(UPDATE_TIME, formatDate(metaObject.getSetterType(CREATE_TIME)), metaObject);
     }
 

cmvr-iot-test/src/main/java/com/cmvr/test/flow/control/FlowControlService.java

@@ -54,7 +54,10 @@ public class FlowControlService {
         if (ctx.isStopped()) {
             throw new GlobalException("任务已终止，无需重复操作");
         }
+        // 异步终止
+        executor.execute(() -> {
             edgeSystemService.stopAll(ctx.getTerminalId());
+        });
 
         // 统一记录日志 + 设置上下文状态 + 数据库状态
         taskInstHolder.syncStatus(instId, TaskStatusEnum.STOPPED);
@@ -78,7 +81,10 @@ public class FlowControlService {
         if (ctx.isPaused()) {
             throw new GlobalException("任务已处于暂停状态");
         }
+        // 异步停止终端
+        executor.execute(() -> {
             edgeSystemService.stopAll(ctx.getTerminalId());
+        });
         ctx.setPaused(true);
         ctx.setTerminalStatus(TerminalStatusEnum.RUNNING);
         ctx.setStatus(TaskStatusEnum.PAUSED);
@@ -144,6 +150,7 @@ public class FlowControlService {
                     TaskNodeExecuteMessage resumeMessage = new TaskNodeExecuteMessage();
                     BeanUtil.copyProperties(pendingNode.getRootMessage(), resumeMessage);
                     resumeMessage.setLoopNum(pendingNode.getLoopIteration());              // 保留中断时的循环次数
+                    resumeMessage.setLoopArray(pendingNode.getLoopArray());              // 保留中断时的循环次数
                     resumeMessage.setIterations(new ArrayList<>(pendingNode.getIterations())); // 保留中断时的路径
 
                     flowItemExecutor.executeNode(
@@ -169,6 +176,7 @@ public class FlowControlService {
                     TaskNodeExecuteMessage resumeMessage = new TaskNodeExecuteMessage();
                     BeanUtil.copyProperties(pendingNode.getRootMessage(), resumeMessage);
                     resumeMessage.setLoopNum(pendingNode.getLoopIteration());              // 保留循环次数
+                    resumeMessage.setLoopArray(pendingNode.getLoopArray());              // 保留循环次数
                     resumeMessage.setIterations(new ArrayList<>(pendingNode.getIterations())); // 保留路径
 
                     flowItemExecutor.executeNode(

cmvr-iot-test/src/main/java/com/cmvr/test/flow/runtime/dispatcher/FlowEndNodeHandler.java

@@ -47,7 +47,7 @@ public class FlowEndNodeHandler implements FlowNodeTypeHandler {
             Thread.currentThread().setName("evaluation-thread-" + Thread.currentThread().getId());
             try {
                 log.info("异步评估任务开始执行：threadName={}, instId={}, itemId={}", Thread.currentThread().getName(), instId, itemId);
-                exAeEvaluationService.executeEvaluation(jsonObject);
+//                exAeEvaluationService.executeEvaluation(jsonObject);
                 log.info("异步评估任务执行结束：threadName={}, instId={}, itemId={}", Thread.currentThread().getName(), instId, itemId);
             } catch (Exception e) {
                 log.error("评估任务执行异常：threadName={}, instId={}, itemId={}, 错误={}", Thread.currentThread().getName(), instId, itemId, e.getMessage(), e);

cmvr-iot-test/src/main/java/com/cmvr/test/flow/runtime/dispatcher/FlowGetCurrentObjNodeHandler.java

@@ -8,6 +8,7 @@ import com.cmvr.test.flow.runtime.message.TaskNodeExecuteResult;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 
+import java.util.Collections;
 import java.util.List;
 
 @Slf4j
@@ -18,17 +19,17 @@ public class FlowGetCurrentObjNodeHandler implements FlowNodeTypeHandler {
     @Override
     public TaskNodeExecuteResult handle(TaskNodeExecuteMessage message) {
         try {
-            JSONObject inputParams = message.getInputParams();
+//            JSONObject inputParams = message.getInputParams();
-            JSONArray jsonArray = inputParams.getJSONArray("array");
+//            JSONArray jsonArray = inputParams.getJSONArray("array");
-
+//
-            List<Integer> iterations = message.getIterations();
+//            List<Integer> iterations = message.getIterations();
-            int last = CollUtil.getLast(iterations) - 1;
+//            int last = CollUtil.getLast(iterations) - 1;
-
+            int index = message.getLoopNum() - 1;
             JSONObject output = new JSONObject();
-            output.put("index", last);
+            output.put("index", index);
-
+            JSONArray objects = (JSONArray)message.getLoopArray();
-            if (CollUtil.isNotEmpty(jsonArray) && last >= 0) {
+            if (CollUtil.isNotEmpty(objects) && index >= 0) {
-                output.put("object", jsonArray.get(last));
+                output.put("object", objects.get(index));
             }
 
             return TaskNodeExecuteResult.success(output);

cmvr-iot-test/src/main/java/com/cmvr/test/flow/runtime/dispatcher/FlowHttpNodeHandler.java

@@ -20,22 +20,30 @@ public class FlowHttpNodeHandler implements FlowNodeTypeHandler {
     public TaskNodeExecuteResult handle(TaskNodeExecuteMessage message) {
         try {
             JSONObject inputParams = message.getInputParams();
+            JSONObject config = inputParams.getJSONObject("config");
+            JSONObject body = inputParams.getJSONObject("body");
+            JSONObject headers = inputParams.getJSONObject("headers");
             // 1. 必填参数校验
-            String url = inputParams.getString("url");
+            String url = config.getString("url");
             if (url == null || url.isEmpty()) {
                 return TaskNodeExecuteResult.failure("HTTP url is required");
             }
 
-            String method = inputParams.getString("method");
+            String method = config.getString("method");
             if (method == null) {
                 method = "POST";
             }
 
-            int timeout = inputParams.getIntValue("timeout", 100000);
+            int timeout = config.getIntValue("timeout", 100000);
 
-            JSONObject headers = inputParams.getJSONObject("headers");
-            Object bodyCfg = inputParams.get("body");
 
+            Object bodyCfg = null;
+            if (!"json".equals(body.getString("bodyType"))) {
+                JSONObject formData = body.getJSONObject("formData");
+                bodyCfg = formData;
+            } else {
+                bodyCfg = body.get("json");
+            }
             // 2. 构造 HTTP 请求
             HttpRequest request = HttpRequest.of(url)
                     .method(Method.valueOf(method.toUpperCase()))

cmvr-iot-test/src/main/java/com/cmvr/test/flow/runtime/dispatcher/FlowLoopNodeHandler.java

@@ -37,6 +37,7 @@ public class FlowLoopNodeHandler implements FlowNodeTypeHandler {
         String nodeId = message.getNodeId();
         FlowNodeWrapper nodeWrapper = graph.getNode(nodeId);
         int loopCount = inputParams.getIntValue("loopNum"); // 获取循环次数
+        Object loopArray = inputParams.get("loopArray"); // 获取循环次数
 
         // 如果没有设置循环次数或者循环次数为 0，则跳过处理
         if (loopCount <= 0) {
@@ -65,8 +66,9 @@ public class FlowLoopNodeHandler implements FlowNodeTypeHandler {
             // 克隆 message，并明确设置 loopNum
             TaskNodeExecuteMessage subMessage = new TaskNodeExecuteMessage();
             BeanUtil.copyProperties(message, subMessage);
-//            subMessage.setLoopNum(i);                  // 当前 loop 第 i 次
+            subMessage.setLoopNum(i);                  // 当前 loop 第 i 次
             subMessage.setIterations(newIterations);   // 完整路径
+            subMessage.setLoopArray(loopArray);
 
             flowItemExecutor.executeSubGraph(subGraph, subMessage, latch::countDown, newIterations);
 

cmvr-iot-test/src/main/java/com/cmvr/test/flow/runtime/engine/FlowItemExecutor.java

@@ -50,7 +50,7 @@ public class FlowItemExecutor {
         FlowGraph graph = FlowModelBuilder.buildExecutableGraph(item.getFlowData());
         String startNodeId = graph.findStartNodeId();
         List<FlowParamDef> startInputDefs = graph.getStartInputParamsDefs();
-
+        startInputDefs.clear();
         // 执行 start 节点（同步执行）
         NodeExecutor executor = node ->
                 executeNode(graph, node, startNodeId, startInputDefs, rootMessage, onFinished, new ArrayList<>());
@@ -73,7 +73,7 @@ public class FlowItemExecutor {
         List<FlowParamDef> startInputDefs = subGraph.getStartInputParamsDefs();
 
         // 子图的 start 节点
-        FlowNodeWrapper subStartNode = subGraph.findSubStartNodeId();
+        FlowNodeWrapper subStartNode = subGraph.getInDegreeZeroNode();
         String subStartNodeId = subStartNode.getNodeId();
 
         NodeExecutor executor = node -> executeNode(
@@ -84,7 +84,7 @@ public class FlowItemExecutor {
         // 执行子图起始节点
         executeNode(subGraph, subStartNode, subStartNodeId, startInputDefs,
                 rootMessage, onFinished, iterations);
-
+        log.info("当前执行-子图");
         // 启动子图调度
         flowTaskScheduler.subStart(subGraph, taskInstHolder.getContext(rootMessage.getInstId()),
                 executor, onFinished, iterations);
@@ -131,7 +131,7 @@ public class FlowItemExecutor {
             }
 
             // END 节点 or 子图结束
-            if (node.getNodeType() == NodeTypeEnum.END || node.getNodeType() == NodeTypeEnum.SUB_END) {
+            if (node.getNodeType() == NodeTypeEnum.END || node.getNodeType() == NodeTypeEnum.SUB_END || graph.isSubGraphEndNode(nodeId)) {
                 try {
                     log.info("{} 节点执行，释放线程", node.getNodeType());
                     onFinished.run();
@@ -172,6 +172,8 @@ public class FlowItemExecutor {
         // loopNum 不在这里计算，而是由 FlowLoopNodeHandler / resume 显式写入
         // 如果 rootMessage 里已经带了 loopNum，就沿用它
         message.setLoopNum(rootMessage.getLoopNum());
+
+        message.setLoopArray(rootMessage.getLoopArray());
         return message;
     }
 

cmvr-iot-test/src/main/java/com/cmvr/test/flow/runtime/engine/FlowTaskRuntimeEntry.java

@@ -42,6 +42,8 @@ public class FlowTaskRuntimeEntry implements FlowTaskRuntimeService {
     private final TaskInstHolder taskInstHolder;
     private final FlowTaskAsyncDispatcher flowTaskAsyncDispatcher;
 
+
+
     @Transactional(rollbackFor = Exception.class)
     public String executeTask(TeTaskExecuteNormalVO taskExecuteNormalVO) {
         return executeTaskInternal(

cmvr-iot-test/src/main/java/com/cmvr/test/flow/runtime/engine/FlowTaskRuntimeService.java

@@ -18,6 +18,7 @@ public interface FlowTaskRuntimeService {
      */
     String executeTask(TeTaskExecuteNormalVO taskExecuteNormalVO);
 
+
     /**
      * 执行试运行任务（TRIAL 模式）
      *

cmvr-iot-test/src/main/java/com/cmvr/test/flow/runtime/engine/FlowTaskScheduler.java

@@ -58,7 +58,7 @@ public class FlowTaskScheduler {
                          Runnable onFinished,
                          List<Integer> iterations) {
         String instId = context.getInstId();
-        FlowNodeWrapper startNode = graph.findSubStartNodeId();
+        FlowNodeWrapper startNode = graph.getInDegreeZeroNode();
         List<String> nextNodes = graph.getNextNodes(startNode.getNodeId());
 
         if (nextNodes.isEmpty()) {

cmvr-iot-test/src/main/java/com/cmvr/test/flow/runtime/engine/support/FlowNodeParamPreparer.java

@@ -1,6 +1,7 @@
 package com.cmvr.test.flow.runtime.engine.support;
 
 import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.collection.CollectionUtil;
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONArray;
 import com.alibaba.fastjson2.JSONObject;
@@ -30,11 +31,65 @@ public class FlowNodeParamPreparer {
                               FlowNodeWrapper node,
                               TaskNodeExecuteMessage rootMessage) {
 
-        JSONObject input = new JSONObject();
+
         TaskContext ctx = taskInstHolder.getContext(rootMessage.getInstId());
 
+        JSONObject input = getInputParams(graph, node.getNodeParams(), rootMessage);
+
+        // 3 START 节点：用 runParams 覆盖默认参数
+        if (node.getNodeType() == NodeTypeEnum.START) {
+            JSONObject merged = new JSONObject(input);
+            JSONObject runParams = ctx.getRunParams();
+            for (String key : runParams.keySet()) {
+                // runParams 里有值，就覆盖掉定义里的值
+                merged.put(key, runParams.get(key));
+            }
+            return merged;
+        }
+
+        // 4 LOOP 节点：动态计算 loopCount
+        if (node.getNodeType() == NodeTypeEnum.LOOP) {
+            Object loopNumVal = input.get("loopNum");
+            input.put("loopArray", loopNumVal);
+            int loopCount = 0;
+
+            // 根据迭代路径找到当前层的集合对象
+//            Object target = resolveLoopTarget(loopNumVal, rootMessage.getIterations(), 0);
+            Object target = loopNumVal;
+            if (target instanceof JSONArray) {
+                loopCount = ((JSONArray) target).size();
+            } else if (target instanceof Collection) {
+                loopCount = ((Collection<?>) target).size();
+            } else if (target != null && target.getClass().isArray()) {
+                loopCount = Array.getLength(target);
+            } else if (target instanceof Number) {
+                loopCount = ((Number) target).intValue();
+            } else if (target != null) {
+                try {
+                    String string = target.toString();
+                    if (string.startsWith("[")) {
+                        JSONArray array = JSON.parseArray(string);
+                        loopCount = array.size();
+                    }else {
+                        loopCount = Integer.parseInt(string);
+                    }
+                } catch (NumberFormatException e) {
+                    throw new GlobalException("loopNum 参数格式错误: " + loopNumVal);
+                }
+            }
+
+            // 写回 inputParams，供 LoopHandler 使用
+            input.put("loopNum", loopCount);
+        }
+
+        return input;
+    }
+
+    private JSONObject getInputParams(FlowGraph graph, List<FlowParamDef> paramDefList, TaskNodeExecuteMessage rootMessage) {
+        JSONObject input = new JSONObject();
+        TaskContext ctx = taskInstHolder.getContext(rootMessage.getInstId());
         // 遍历当前节点定义的参数
-        for (FlowParamDef param : node.getNodeParams()) {
+        for (FlowParamDef param : paramDefList) {
             if (param.getScope() != ParamScope.NODE) continue;
 
             // 1 静态 input 参数
@@ -68,53 +123,11 @@ public class FlowNodeParamPreparer {
                 Object val = findNestedValue(source, path);
                 input.put(param.getName(), val);
             }
-        }
+            if (!CollectionUtil.isEmpty(param.getChildren())) {
-
+                // 添加子参数
-        // 3 START 节点：用 runParams 覆盖默认参数
+                input.put(param.getName(), getInputParams(graph, param.getChildren(), rootMessage));
-        if (node.getNodeType() == NodeTypeEnum.START) {
-            JSONObject merged = new JSONObject(input);
-            JSONObject runParams = ctx.getRunParams();
-            for (String key : runParams.keySet()) {
-                // runParams 里有值，就覆盖掉定义里的值
-                merged.put(key, runParams.get(key));
-            }
-            return merged;
-        }
-
-        // 4 LOOP 节点：动态计算 loopCount
-        if (node.getNodeType() == NodeTypeEnum.LOOP) {
-            Object loopNumVal = input.get("loopNum");
-            int loopCount = 0;
-
-            // 根据迭代路径找到当前层的集合对象
-            Object target = resolveLoopTarget(loopNumVal, rootMessage.getIterations(), 0);
-
-            if (target instanceof JSONArray) {
-                loopCount = ((JSONArray) target).size();
-            } else if (target instanceof Collection) {
-                loopCount = ((Collection<?>) target).size();
-            } else if (target != null && target.getClass().isArray()) {
-                loopCount = Array.getLength(target);
-            } else if (target instanceof Number) {
-                loopCount = ((Number) target).intValue();
-            } else if (target != null) {
-                try {
-                    String string = target.toString();
-                    if (string.startsWith("[")) {
-                        JSONArray array = JSON.parseArray(string);
-                        loopCount = array.size();
-                    }else {
-                        loopCount = Integer.parseInt(string);
-                    }
-                } catch (NumberFormatException e) {
-                    throw new GlobalException("loopNum 参数格式错误: " + loopNumVal);
             }
         }
-
-            // 写回 inputParams，供 LoopHandler 使用
-            input.put("loopNum", loopCount);
-        }
-
         return input;
     }
 

cmvr-iot-test/src/main/java/com/cmvr/test/flow/runtime/message/TaskNodeExecuteContext.java

@@ -22,5 +22,6 @@ public class TaskNodeExecuteContext {
     private TaskNodeExecuteMessage rootMessage;
     private Runnable onFinished;
     private int loopIteration;
+    private Object loopArray;
     private List<Integer> iterations = new ArrayList<>();
 }

cmvr-iot-test/src/main/java/com/cmvr/test/flow/runtime/message/TaskNodeExecuteMessage.java

@@ -55,6 +55,8 @@ public class TaskNodeExecuteMessage {
      */
     private List<Integer> iterations = new ArrayList<>();
 
+    private Object loopArray;
+
     /**
      * 节点名称
      */

cmvr-iot-test/src/main/java/com/cmvr/test/flow/runtime/operator/llm/LLMAiAgentPlatformOperateService.java

@@ -12,6 +12,7 @@ import org.springframework.stereotype.Service;
 
 @Slf4j
 @Service
+
 @RequiredArgsConstructor
 public class LLMAiAgentPlatformOperateService implements LLMOperateService {
 
@@ -26,10 +27,11 @@ public class LLMAiAgentPlatformOperateService implements LLMOperateService {
     public TaskNodeExecuteResult execute(TaskNodeExecuteMessage message) {
         ActionEnum action = message.getAction();
         JSONObject inputParams = message.getInputParams();
-        String text = inputParams.getString("text");
+        JSONObject config = inputParams.getJSONObject("config");
-        String apiKey = inputParams.getString("apiKey");
+        String text = config.getString("text");
-
+        String apiKey = config.getString("apiKey");
-        JSONObject output = llmAiAgentPlatformService.query(action.name(), text, apiKey);
+        Boolean invokeTts = inputParams.getBoolean("invokeTts");
+        JSONObject output =llmAiAgentPlatformService.query(action.name(), text, apiKey, invokeTts, inputParams.getJSONObject("tts"));
 
         return TaskNodeExecuteResult.success(output);
     }

cmvr-iot-test/src/main/java/com/cmvr/test/service/FlowActionExecutorService.java

@@ -12,6 +12,8 @@ import com.cmvr.edge.client.service.EdgeCameraService;
 import com.cmvr.edge.client.service.EdgeHlcService;
 import com.cmvr.edge.client.service.EdgeMicrophoneService;
 import com.cmvr.edge.client.service.EdgeSpeakerService;
+import com.cmvr.llm.service.LLMAiAgentPlatformService;
+import com.cmvr.llm.service.LLMAiTtsService;
 import com.cmvr.test.enums.ActionEnum;
 import com.cmvr.test.model.vo.FlowActionRequestVO;
 import lombok.RequiredArgsConstructor;
@@ -27,6 +29,8 @@ public class FlowActionExecutorService {
     private final EdgeMicrophoneService edgeMicrophoneService;
     private final EdgeSpeakerService edgeSpeakerService;
     private final EdgeHlcService edgeHlcService;
+    private final LLMAiTtsService llmAiTtsService;
+    private final LLMAiAgentPlatformService llmAiAgentPlatformService;
 
     public String actionExecute(FlowActionRequestVO req) {
 
@@ -115,6 +119,8 @@ public class FlowActionExecutorService {
                 return "LLM 意图识别 OK";
             case GENERATE_ADVANCED_AUDIO:
                 return "LLM 高级音频生成 OK";
+            case AI_AGENT_PLATFORM:
+                return llmAiAgentPlatformService.query(action.getAction(), req.getPayload().getJSONObject("config").getString("text"), req.getPayload().getJSONObject("config").getString("apiKey"), req.getPayload().getBoolean("invokeTts"), req.getPayload().getJSONObject("tts")).toString();
             default:
                 throw new UnsupportedOperationException("未实现的 LLM Action: " + action);
         }

cmvr-iot-ti/src/main/java/com/cmvr/ti/service/impl/TiVehicleFunctionServiceImpl.java

@@ -40,7 +40,7 @@ public class TiVehicleFunctionServiceImpl extends ServiceImpl<TiVehicleFunctionM
     @Override
     public JSONObject selectTiVehicleFunctionDetailById(Long id) {
         JSONObject jsonObject = JSONObject.from(this.getById(id));
-        jsonObject.put("funcName", id== 26 ? "首页" : "设置");
+        jsonObject.put("funcName", sysDictDataService.selectDictLabel("ti_function_config", jsonObject.getString("funcKey")));
         return jsonObject;
     }