xieyinlu/ruoyi-ai
1
0
Fork 0
mirror of https://gitcode.com/ageerle/ruoyi-ai.git synced 2026-04-12 02:57:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: 修复工作流执行报错，没有用户消息

Browse Source
This commit is contained in:
radish@2020
2025-10-21 18:00:46 +08:00
parent 35c848b719
commit 6b5fea27e0
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
ruoyi-modules-api/ruoyi-workflow-api/src/main/java/org/ruoyi/workflow/workflow/WorkflowUtil.java
View File

@@ -123,14 +123,14 @@ public class WorkflowUtil {
Set<String> nameSet = CollStreamUtil.toSet(refInputs, WfNodeParamRef::getName); Set<String> nameSet = CollStreamUtil.toSet(refInputs, WfNodeParamRef::getName);
userMessage.stream().filter(item -> nameSet.contains(item.getName())) userMessage.stream().filter(item -> nameSet.contains(item.getName()))
.map(item -> getMessage("role", item.getContent().getValue())).forEach(messages::add); .map(item -> getMessage("user", item.getContent().getValue())).forEach(messages::add);
if (CollUtil.isNotEmpty(messages)) { if (CollUtil.isNotEmpty(messages)) {
return; return;
} }
userMessage.stream().filter(item -> "input".equals(item.getName())) userMessage.stream().filter(item -> "input".equals(item.getName()))
.map(item -> getMessage("role", item.getContent().getValue())).forEach(messages::add); .map(item -> getMessage("user", item.getContent().getValue())).forEach(messages::add);
} }
/** /**