From f6af2843634098b98a73ed66ce260c66025f45e7 Mon Sep 17 00:00:00 2001
From: stream <strean4y@163.com>
Date: Fri, 12 Dec 2025 15:20:22 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20flowise=20=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/cmvr/test/service/FlowiseActionService.java    | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git a/cmvr-iot-test/src/main/java/com/cmvr/test/service/FlowiseActionService.java b/cmvr-iot-test/src/main/java/com/cmvr/test/service/FlowiseActionService.java
index 7b8bd86..79a227a 100644
--- a/cmvr-iot-test/src/main/java/com/cmvr/test/service/FlowiseActionService.java
+++ b/cmvr-iot-test/src/main/java/com/cmvr/test/service/FlowiseActionService.java
@@ -57,7 +57,7 @@ public class FlowiseActionService {
     private String chatId = null;
 
     public String start(FlowiseStartRequestVO request) {
-        log.info("flowise start");
+        log.info("flowise start: {}", System.currentTimeMillis());
         abort();
         synchronized (lock) {
             if (chatId != null) {
@@ -91,9 +91,7 @@ public class FlowiseActionService {
     public String abort() {
         CallAPIUtil.doPostJson(flowiseTts + "stop", null, null);
         Map<String, TaskContext> instContextMap = taskContextManager.getInstContextMap();
-        instContextMap.forEach((key, value) -> {
-            flowControlService.stop(key);
-        });
+        instContextMap.forEach((key, value) -> flowControlService.stop(key));
         synchronized (lock) {
 
             if (chatId == null) {
@@ -114,7 +112,7 @@ public class FlowiseActionService {
     }
 
     public String command(FlowiseActionRequestVO request) {
-        log.info("command start");
+        log.info("command start: {}", System.currentTimeMillis());
         String action = request.getAction();
         FlowiseActionEnum actionEnum = FlowiseActionEnum.fromAction(action);
         String terminalId = "4ed1246c465b97975f96c9ef8371a3bd";
@@ -142,7 +140,7 @@ public class FlowiseActionService {
     }
 
     public String chat(FlowiseChatRequestVO requestVO) {
-        log.info("chat start");
+        log.info("chat start: {}", System.currentTimeMillis());
         Map<String, String> body = new HashMap<>();
         body.put("text", requestVO.getText());
         body.put("voice", "x4_yezi");