SmartBench/CMVR-IOT
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: flowise 调整

Browse Source
This commit is contained in:
stream 2025-12-12 15:20:22 +08:00
parent 2f852ead1f
commit f6af284363
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
cmvr-iot-test/src/main/java/com/cmvr/test/service/FlowiseActionService.java
View File

@ -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");