mirror of
https://gitcode.com/ageerle/ruoyi-ai.git
synced 2026-04-12 02:57:20 +00:00
@@ -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);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
@@ -3,7 +3,7 @@ CREATE TABLE t_workflow
|
|||||||
id BIGINT AUTO_INCREMENT PRIMARY KEY,
|
id BIGINT AUTO_INCREMENT PRIMARY KEY,
|
||||||
uuid VARCHAR(32) NOT NULL DEFAULT '',
|
uuid VARCHAR(32) NOT NULL DEFAULT '',
|
||||||
title VARCHAR(100) NOT NULL DEFAULT '',
|
title VARCHAR(100) NOT NULL DEFAULT '',
|
||||||
remark TEXT NOT NULL DEFAULT '',
|
remark TEXT NOT NULL,
|
||||||
user_id BIGINT NOT NULL DEFAULT 0,
|
user_id BIGINT NOT NULL DEFAULT 0,
|
||||||
is_public TINYINT(1) NOT NULL DEFAULT 0,
|
is_public TINYINT(1) NOT NULL DEFAULT 0,
|
||||||
is_enable TINYINT(1) NOT NULL DEFAULT 1,
|
is_enable TINYINT(1) NOT NULL DEFAULT 1,
|
||||||
|
|||||||
Reference in New Issue
Block a user