Compare commits
9 Commits
868fd0658c
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
| be0f0ed4d7 | |||
| eaef9a0e4c | |||
| 09a567a542 | |||
| e169065653 | |||
| 63d3e7eecb | |||
| c607316f53 | |||
| 155f31121f | |||
| d8acb2130d | |||
| c141d895db |
Binary file not shown.
@@ -25,6 +25,7 @@
|
||||
"ai": "^6.0.39",
|
||||
"aplayer": "^1.10.1",
|
||||
"class-variance-authority": "^0.7.1",
|
||||
"clipboard-polyfill": "^4.1.1",
|
||||
"clsx": "^2.1.1",
|
||||
"date-fns": "^4.1.0",
|
||||
"dayjs": "^1.11.18",
|
||||
|
||||
@@ -21,10 +21,11 @@ export function getAgentList() {
|
||||
/**
|
||||
* 流式对话(SSE)
|
||||
* @param {Object} options - 请求配置
|
||||
* @param {number} options.agentId - 智能体ID
|
||||
* @param {number} [options.agentId] - 智能体ID(使用 customSystemPrompt 时可不传)
|
||||
* @param {string} options.content - 用户输入内容
|
||||
* @param {string} [options.conversationId] - 会话ID(可选,首次对话不传)
|
||||
* @param {string} [options.modelMode] - 模型模式:pro-深度版 standard-标准版
|
||||
* @param {string} [options.customSystemPrompt] - 自定义系统提示词(使用用户自建风格时传入)
|
||||
* @param {AbortController} [options.ctrl] - 取消控制器
|
||||
* @param {Function} options.onMessage - 消息回调
|
||||
* @param {Function} [options.onError] - 错误回调
|
||||
@@ -36,6 +37,8 @@ export async function sendChatStream(options) {
|
||||
content,
|
||||
conversationId,
|
||||
modelMode = 'pro',
|
||||
customSystemPrompt,
|
||||
source,
|
||||
ctrl,
|
||||
onMessage,
|
||||
onError,
|
||||
@@ -56,7 +59,9 @@ export async function sendChatStream(options) {
|
||||
agentId,
|
||||
content,
|
||||
conversationId,
|
||||
modelMode
|
||||
modelMode,
|
||||
customSystemPrompt,
|
||||
source
|
||||
}),
|
||||
onmessage: (event) => {
|
||||
if (typeof onMessage === 'function') {
|
||||
@@ -86,10 +91,11 @@ export async function sendChatStream(options) {
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取会话列表
|
||||
* 获取会话列表(合并 pro + standard 两个 Dify 工作流)
|
||||
* @param {Object} params - 请求参数
|
||||
* @param {number} params.agentId - 智能体ID
|
||||
* @param {string} [params.lastId] - 上一页最后一条记录ID
|
||||
* @param {string} [params.source] - 来源类型:agent-智能体 prompt-自建风格
|
||||
* @param {string} [params.cursor] - 复合游标(首页不传)
|
||||
* @param {number} [params.limit] - 返回条数,默认20
|
||||
*/
|
||||
export function getConversations(params) {
|
||||
@@ -101,10 +107,12 @@ export function getConversations(params) {
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取会话历史消息
|
||||
* 获取会话历史消息(自动定位 pro/standard App)
|
||||
* @param {Object} params - 请求参数
|
||||
* @param {number} params.agentId - 智能体ID
|
||||
* @param {string} [params.source] - 来源类型:agent-智能体 prompt-自建风格
|
||||
* @param {string} params.conversationId - 会话ID
|
||||
* @param {string} [params.appSource] - 来源应用标识:pro/standard
|
||||
* @param {string} [params.firstId] - 当前页第一条记录ID
|
||||
* @param {number} [params.limit] - 返回条数,默认20
|
||||
*/
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
<script setup>
|
||||
import { ref, watch, nextTick } from 'vue'
|
||||
import { ref, computed, watch, nextTick } from 'vue'
|
||||
import { Icon } from '@iconify/vue'
|
||||
import { toast } from 'vue-sonner'
|
||||
import {
|
||||
@@ -33,7 +33,46 @@ const props = defineProps({
|
||||
|
||||
const emit = defineEmits(['update:visible', 'send'])
|
||||
|
||||
// State
|
||||
const isPromptScene = computed(() => props.agent?.source === 'prompt')
|
||||
|
||||
function buildRequestOptions(prompt, ctrl) {
|
||||
const base = {
|
||||
agentId: props.agent?.id,
|
||||
source: props.agent?.source || 'agent',
|
||||
content: prompt,
|
||||
modelMode: modelMode.value,
|
||||
ctrl,
|
||||
onMessage: handleStreamMessage,
|
||||
onError: handleStreamError,
|
||||
onClose: handleStreamClose
|
||||
}
|
||||
|
||||
if (isPromptScene.value) {
|
||||
base.customSystemPrompt = props.agent.customSystemPrompt
|
||||
}
|
||||
|
||||
return base
|
||||
}
|
||||
|
||||
function handleStreamMessage(result) {
|
||||
if (result.event === 'message' && result.content) {
|
||||
generatedContent.value += result.content
|
||||
scrollToBottom()
|
||||
} else if (result.event === 'error') {
|
||||
toast.error(result.errorMessage || '生成出错')
|
||||
}
|
||||
}
|
||||
|
||||
function handleStreamError() {
|
||||
toast.error('生成失败')
|
||||
if (!generatedContent.value) isGenerating.value = false
|
||||
}
|
||||
|
||||
function handleStreamClose() {
|
||||
isGenerating.value = false
|
||||
abortController.value = null
|
||||
}
|
||||
|
||||
const modelMode = ref('pro')
|
||||
const inputText = ref('')
|
||||
const isGenerating = ref(false)
|
||||
@@ -44,7 +83,6 @@ const abortController = ref(null)
|
||||
const historyVisible = ref(false)
|
||||
const showCloseConfirm = ref(false)
|
||||
|
||||
// Methods
|
||||
const handleClose = (open) => {
|
||||
if (!open) {
|
||||
if (isGenerating.value) {
|
||||
@@ -122,28 +160,7 @@ const executeStreamRequest = async (prompt) => {
|
||||
abortController.value = new AbortController()
|
||||
|
||||
try {
|
||||
await sendChatStream({
|
||||
agentId: props.agent?.id,
|
||||
content: prompt,
|
||||
modelMode: modelMode.value,
|
||||
ctrl: abortController.value,
|
||||
onMessage: (result) => {
|
||||
if (result.event === 'message' && result.content) {
|
||||
generatedContent.value += result.content
|
||||
scrollToBottom()
|
||||
} else if (result.event === 'error') {
|
||||
toast.error(result.errorMessage || '生成出错')
|
||||
}
|
||||
},
|
||||
onError: () => {
|
||||
toast.error('生成失败')
|
||||
if (!generatedContent.value) isGenerating.value = false
|
||||
},
|
||||
onClose: () => {
|
||||
isGenerating.value = false
|
||||
abortController.value = null
|
||||
}
|
||||
})
|
||||
await sendChatStream(buildRequestOptions(prompt, abortController.value))
|
||||
} catch (error) {
|
||||
if (error.name !== 'AbortError') toast.error('生成失败')
|
||||
isGenerating.value = false
|
||||
@@ -170,7 +187,7 @@ watch(() => props.visible, (val) => {
|
||||
|
||||
<template>
|
||||
<Sheet :open="visible" @update:open="handleClose">
|
||||
<SheetContent side="right" class="w-full sm:w-[420px] md:w-[560px] lg:w-[640px] p-0 flex flex-col bg-background">
|
||||
<SheetContent side="right" class="w-full sm:w-[520px] md:w-[680px] lg:w-[800px] p-0 flex flex-col bg-background">
|
||||
<!-- Header -->
|
||||
<SheetHeader class="shrink-0">
|
||||
<ChatDrawerHeader :agent="agent" @history="openHistory" />
|
||||
@@ -208,6 +225,7 @@ watch(() => props.visible, (val) => {
|
||||
<HistoryPanel
|
||||
:visible="historyVisible"
|
||||
:agent-id="agent?.id"
|
||||
:source="agent?.source || 'agent'"
|
||||
@close="closeHistory"
|
||||
/>
|
||||
|
||||
|
||||
@@ -1,31 +1,45 @@
|
||||
<script setup>
|
||||
import { computed } from 'vue'
|
||||
import { Icon } from '@iconify/vue'
|
||||
import { Button } from '@/components/ui/button'
|
||||
|
||||
defineProps({
|
||||
const props = defineProps({
|
||||
agent: { type: Object, default: null }
|
||||
})
|
||||
|
||||
const emit = defineEmits(['history'])
|
||||
|
||||
const isPromptScene = computed(() => props.agent?.source === 'prompt')
|
||||
|
||||
const openHistory = () => emit('history')
|
||||
</script>
|
||||
|
||||
<template>
|
||||
<div class="flex items-center justify-between px-4 py-3 border-b border-border/50 shrink-0 bg-gradient-to-r from-background to-muted/30">
|
||||
<div class="flex items-center gap-3">
|
||||
<div class="size-10 rounded-xl bg-gradient-to-br from-primary to-violet-500 flex items-center justify-center overflow-hidden shadow-sm shadow-primary/20">
|
||||
<div
|
||||
class="size-10 rounded-xl flex items-center justify-center overflow-hidden shadow-sm"
|
||||
:class="isPromptScene
|
||||
? 'bg-gradient-to-br from-amber-400 to-orange-500 shadow-amber-200/30'
|
||||
: 'bg-gradient-to-br from-primary to-violet-500 shadow-primary/20'"
|
||||
>
|
||||
<img
|
||||
v-if="agent?.avatar"
|
||||
:src="agent.avatar"
|
||||
:alt="agent.name"
|
||||
class="w-full h-full object-cover"
|
||||
/>
|
||||
<Icon v-else icon="lucide:bot" class="text-white text-xl" />
|
||||
<Icon v-else :icon="isPromptScene ? 'lucide:sparkles' : 'lucide:bot'" class="text-white text-xl" />
|
||||
</div>
|
||||
<div>
|
||||
<div class="font-semibold text-foreground text-sm">{{ agent?.name || 'AI 助手' }}</div>
|
||||
<div class="text-xs text-muted-foreground">{{ agent?.categoryName || '通用' }}</div>
|
||||
<div class="text-xs text-muted-foreground">
|
||||
<span v-if="isPromptScene" class="inline-flex items-center gap-1">
|
||||
<Icon icon="lucide:pencil" class="size-3" />
|
||||
{{ agent?.categoryName || '我的风格' }}
|
||||
</span>
|
||||
<span v-else>{{ agent?.categoryName || '通用' }}</span>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<Button
|
||||
|
||||
@@ -172,7 +172,8 @@ import { copyToClipboard } from '@/utils/clipboard'
|
||||
|
||||
const props = defineProps({
|
||||
visible: { type: Boolean, default: false },
|
||||
agentId: { type: [String, Number], default: null }
|
||||
agentId: { type: [String, Number], default: null },
|
||||
source: { type: String, default: 'agent' }
|
||||
})
|
||||
|
||||
const emit = defineEmits(['close'])
|
||||
@@ -183,7 +184,7 @@ const conversationList = ref([])
|
||||
const selectedConversation = ref(null)
|
||||
const messageList = ref([])
|
||||
const messageLoading = ref(false)
|
||||
const lastId = ref(null)
|
||||
const cursor = ref(null)
|
||||
const hasMore = ref(true)
|
||||
|
||||
// 按日期分组(先排序再分组)
|
||||
@@ -229,9 +230,9 @@ const loadConversations = async (loadMore = false) => {
|
||||
|
||||
loading.value = true
|
||||
try {
|
||||
const params = { agentId: props.agentId, limit: 20 }
|
||||
if (loadMore && lastId.value) {
|
||||
params.lastId = lastId.value
|
||||
const params = { agentId: props.agentId, source: props.source, limit: 20 }
|
||||
if (loadMore && cursor.value) {
|
||||
params.cursor = cursor.value
|
||||
}
|
||||
const res = await getConversations(params)
|
||||
if (res.code === 0) {
|
||||
@@ -241,9 +242,9 @@ const loadConversations = async (loadMore = false) => {
|
||||
} else {
|
||||
conversationList.value = data
|
||||
}
|
||||
// 更新分页状态
|
||||
lastId.value = data.length > 0 ? data[data.length - 1].id : null
|
||||
hasMore.value = data.length === 20 && res.data?.hasMore !== false
|
||||
// 更新分页状态:使用后端返回的复合游标
|
||||
cursor.value = res.data?.nextCursor || null
|
||||
hasMore.value = res.data?.hasMore !== false && data.length > 0
|
||||
}
|
||||
} catch (e) {
|
||||
console.error('加载会话列表失败:', e)
|
||||
@@ -259,7 +260,9 @@ const selectConversation = async (conversation) => {
|
||||
try {
|
||||
const res = await getMessages({
|
||||
agentId: props.agentId,
|
||||
source: props.source,
|
||||
conversationId: conversation.id,
|
||||
appSource: conversation.appSource,
|
||||
limit: 50
|
||||
})
|
||||
if (res.code === 0) {
|
||||
@@ -318,8 +321,7 @@ watch(() => props.visible, (val) => {
|
||||
.history-overlay {
|
||||
position: fixed;
|
||||
inset: 0;
|
||||
background: rgba(15, 23, 42, 0.4);
|
||||
backdrop-filter: blur(8px);
|
||||
background: rgba(15, 23, 42, 0.5);
|
||||
z-index: 2000;
|
||||
display: flex;
|
||||
align-items: center;
|
||||
@@ -341,18 +343,19 @@ watch(() => props.visible, (val) => {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
overflow: hidden;
|
||||
will-change: transform, opacity;
|
||||
}
|
||||
|
||||
.modal-glow {
|
||||
position: absolute;
|
||||
top: -50%;
|
||||
left: -50%;
|
||||
width: 200%;
|
||||
height: 200%;
|
||||
top: 0;
|
||||
left: 0;
|
||||
width: 100%;
|
||||
height: 200px;
|
||||
background: radial-gradient(
|
||||
circle at 30% 20%,
|
||||
rgba(59, 130, 246, 0.08) 0%,
|
||||
transparent 40%
|
||||
ellipse at 30% 0%,
|
||||
rgba(59, 130, 246, 0.06) 0%,
|
||||
transparent 60%
|
||||
);
|
||||
pointer-events: none;
|
||||
}
|
||||
@@ -439,7 +442,8 @@ watch(() => props.visible, (val) => {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
justify-content: center;
|
||||
transition: all 0.2s ease;
|
||||
will-change: transform;
|
||||
transition: transform 0.2s ease, background 0.2s ease, color 0.2s ease;
|
||||
|
||||
&:hover {
|
||||
background: var(--color-error-100);
|
||||
@@ -508,6 +512,7 @@ watch(() => props.visible, (val) => {
|
||||
inset: 0;
|
||||
border-radius: 50%;
|
||||
border: 2px solid var(--color-gray-200);
|
||||
will-change: opacity;
|
||||
animation: ringPulse 3s ease-in-out infinite;
|
||||
|
||||
&.delay-1 {
|
||||
@@ -518,11 +523,9 @@ watch(() => props.visible, (val) => {
|
||||
|
||||
@keyframes ringPulse {
|
||||
0%, 100% {
|
||||
transform: scale(1);
|
||||
opacity: 0.5;
|
||||
}
|
||||
50% {
|
||||
transform: scale(1.05);
|
||||
opacity: 1;
|
||||
}
|
||||
}
|
||||
@@ -562,6 +565,7 @@ watch(() => props.visible, (val) => {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 24px;
|
||||
contain: layout style;
|
||||
}
|
||||
|
||||
.load-more {
|
||||
@@ -595,8 +599,9 @@ watch(() => props.visible, (val) => {
|
||||
}
|
||||
|
||||
.conversation-group {
|
||||
animation: groupFadeIn 0.4s ease-out backwards;
|
||||
animation-delay: calc(var(--group-index) * 0.1s);
|
||||
will-change: opacity;
|
||||
animation: groupFadeIn 0.3s ease-out backwards;
|
||||
animation-delay: calc(var(--group-index) * 0.06s);
|
||||
}
|
||||
|
||||
@keyframes groupFadeIn {
|
||||
@@ -645,6 +650,7 @@ watch(() => props.visible, (val) => {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 8px;
|
||||
contain: layout style;
|
||||
}
|
||||
|
||||
// ========================================
|
||||
@@ -661,17 +667,15 @@ watch(() => props.visible, (val) => {
|
||||
border-radius: 14px;
|
||||
cursor: pointer;
|
||||
text-align: left;
|
||||
transition: all 0.25s ease;
|
||||
animation: itemFadeIn 0.3s ease-out backwards;
|
||||
animation-delay: calc(var(--group-index) * 0.1s + var(--item-index) * 0.05s);
|
||||
contain: content;
|
||||
will-change: transform, opacity;
|
||||
transition: transform 0.2s ease, border-color 0.2s ease;
|
||||
animation: itemFadeIn 0.25s ease-out backwards;
|
||||
animation-delay: calc(var(--group-index) * 0.06s + var(--item-index) * 0.03s);
|
||||
|
||||
&:hover {
|
||||
border-color: var(--color-primary-300);
|
||||
background: rgba(59, 130, 246, 0.02);
|
||||
box-shadow:
|
||||
0 4px 12px rgba(59, 130, 246, 0.08),
|
||||
0 0 0 1px rgba(59, 130, 246, 0.1);
|
||||
transform: translateY(-2px);
|
||||
transform: translateY(-1px);
|
||||
|
||||
.item-indicator {
|
||||
background: var(--color-primary-500);
|
||||
@@ -688,11 +692,11 @@ watch(() => props.visible, (val) => {
|
||||
@keyframes itemFadeIn {
|
||||
from {
|
||||
opacity: 0;
|
||||
transform: translateX(-8px);
|
||||
transform: translateY(6px);
|
||||
}
|
||||
to {
|
||||
opacity: 1;
|
||||
transform: translateX(0);
|
||||
transform: translateY(0);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -702,7 +706,8 @@ watch(() => props.visible, (val) => {
|
||||
border-radius: 2px;
|
||||
background: var(--color-gray-200);
|
||||
flex-shrink: 0;
|
||||
transition: all 0.25s ease;
|
||||
will-change: transform;
|
||||
transition: transform 0.2s ease, background 0.2s ease;
|
||||
transform: scaleY(0.6);
|
||||
}
|
||||
|
||||
@@ -755,7 +760,8 @@ watch(() => props.visible, (val) => {
|
||||
justify-content: center;
|
||||
color: var(--color-gray-300);
|
||||
font-size: 10px;
|
||||
transition: all 0.25s ease;
|
||||
will-change: transform;
|
||||
transition: transform 0.2s ease, color 0.2s ease;
|
||||
}
|
||||
|
||||
// ========================================
|
||||
@@ -769,11 +775,13 @@ watch(() => props.visible, (val) => {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 24px;
|
||||
contain: layout style;
|
||||
}
|
||||
|
||||
.timeline-item {
|
||||
animation: msgFadeIn 0.35s ease-out backwards;
|
||||
animation-delay: calc(var(--msg-index) * 0.08s);
|
||||
will-change: opacity;
|
||||
animation: msgFadeIn 0.25s ease-out backwards;
|
||||
animation-delay: calc(var(--msg-index) * 0.04s);
|
||||
}
|
||||
|
||||
@keyframes msgFadeIn {
|
||||
|
||||
@@ -60,6 +60,7 @@ async function loadList() {
|
||||
promptList.value = res.data.map(item => ({
|
||||
id: item.id,
|
||||
name: item.name,
|
||||
content: item.content,
|
||||
category: item.category,
|
||||
useCount: item.useCount || 0
|
||||
}))
|
||||
@@ -93,9 +94,11 @@ async function handleDelete(id) {
|
||||
|
||||
function handleUse(item) {
|
||||
emit('chat', {
|
||||
source: 'prompt',
|
||||
id: item.id,
|
||||
name: item.name,
|
||||
categoryName: item.category || '我的风格'
|
||||
categoryName: item.category || '我的风格',
|
||||
customSystemPrompt: item.content
|
||||
})
|
||||
handleClose()
|
||||
}
|
||||
|
||||
@@ -39,9 +39,9 @@ const forwarded = useForwardPropsEmits(delegatedProps, emits)
|
||||
:class="cn(
|
||||
'bg-background data-[state=open]:animate-in data-[state=closed]:animate-out fixed z-50 flex flex-col gap-4 shadow-lg transition ease-in-out data-[state=closed]:duration-300 data-[state=open]:duration-500',
|
||||
side === 'right'
|
||||
&& 'data-[state=closed]:slide-out-to-right data-[state=open]:slide-in-from-right inset-y-0 right-0 h-full w-3/4 border-l sm:max-w-sm',
|
||||
&& 'data-[state=closed]:slide-out-to-right data-[state=open]:slide-in-from-right inset-y-0 right-0 h-full w-3/4 border-l sm:max-w-2xl',
|
||||
side === 'left'
|
||||
&& 'data-[state=closed]:slide-out-to-left data-[state=open]:slide-in-from-left inset-y-0 left-0 h-full w-3/4 border-r sm:max-w-sm',
|
||||
&& 'data-[state=closed]:slide-out-to-left data-[state=open]:slide-in-from-left inset-y-0 left-0 h-full w-3/4 border-r sm:max-w-2xl',
|
||||
side === 'top'
|
||||
&& 'data-[state=closed]:slide-out-to-top data-[state=open]:slide-in-from-top inset-x-0 top-0 h-auto border-b',
|
||||
side === 'bottom'
|
||||
|
||||
@@ -1,41 +1,17 @@
|
||||
import * as clipboardPolyfill from 'clipboard-polyfill'
|
||||
|
||||
/**
|
||||
* 复制文本到剪贴板
|
||||
* 兼容非 HTTPS 环境的降级方案
|
||||
* 使用 clipboard-polyfill 兼容非 HTTPS 环境
|
||||
*/
|
||||
export async function copyToClipboard(text: string): Promise<boolean> {
|
||||
if (!text?.trim()) {
|
||||
return false
|
||||
}
|
||||
|
||||
// 优先使用 Clipboard API(需要 HTTPS 或 localhost)
|
||||
if (navigator.clipboard?.writeText) {
|
||||
try {
|
||||
await navigator.clipboard.writeText(text)
|
||||
return true
|
||||
} catch {
|
||||
// 降级到 execCommand 方案
|
||||
}
|
||||
}
|
||||
|
||||
// 降级方案:使用 textarea + execCommand
|
||||
return fallbackCopy(text)
|
||||
}
|
||||
|
||||
/**
|
||||
* 降级复制方案
|
||||
*/
|
||||
function fallbackCopy(text: string): boolean {
|
||||
try {
|
||||
const textarea = document.createElement('textarea')
|
||||
textarea.value = text
|
||||
textarea.style.position = 'fixed'
|
||||
textarea.style.opacity = '0'
|
||||
textarea.style.left = '-9999px'
|
||||
document.body.appendChild(textarea)
|
||||
textarea.select()
|
||||
const success = document.execCommand('copy')
|
||||
document.body.removeChild(textarea)
|
||||
return success
|
||||
await clipboardPolyfill.writeText(text)
|
||||
return true
|
||||
} catch {
|
||||
return false
|
||||
}
|
||||
|
||||
@@ -280,6 +280,7 @@ const fetchAgentList = async () => {
|
||||
const res = await getAgentList()
|
||||
if (res.code === 0 && res.data) {
|
||||
agentList.value = res.data.map(item => ({
|
||||
source: 'agent',
|
||||
id: item.id,
|
||||
agentId: item.agentId,
|
||||
name: item.agentName,
|
||||
|
||||
@@ -22,26 +22,14 @@
|
||||
|
||||
<!-- 内容区 -->
|
||||
<div class="popover-body">
|
||||
<!-- 智能体选择 -->
|
||||
<!-- 风格选择 -->
|
||||
<div class="form-item">
|
||||
<label class="form-label">选择智能体</label>
|
||||
<Select v-model="selectedAgentId" :disabled="loadingAgents" class="agent-select">
|
||||
<SelectTrigger class="agent-select-trigger">
|
||||
<SelectValue :placeholder="loadingAgents ? '加载中...' : '请选择智能体'" />
|
||||
</SelectTrigger>
|
||||
<SelectContent>
|
||||
<SelectItem
|
||||
v-for="agent in agentList"
|
||||
:key="agent.id"
|
||||
:value="agent.id"
|
||||
>
|
||||
<div class="agent-option">
|
||||
<img v-if="agent.icon" :src="agent.icon" class="agent-icon" />
|
||||
<span class="agent-name">{{ agent.agentName }}</span>
|
||||
</div>
|
||||
</SelectItem>
|
||||
</SelectContent>
|
||||
</Select>
|
||||
<label class="form-label">选择风格</label>
|
||||
<StyleSelector
|
||||
v-model:value="selectedAgentId"
|
||||
placeholder="选择风格"
|
||||
storage-key="text_generate_style"
|
||||
/>
|
||||
</div>
|
||||
|
||||
<!-- 主题输入 -->
|
||||
@@ -88,14 +76,8 @@
|
||||
import { ref, computed, watch, onUnmounted } from 'vue'
|
||||
import { Icon } from '@iconify/vue'
|
||||
import { toast } from 'vue-sonner'
|
||||
import {
|
||||
Select,
|
||||
SelectContent,
|
||||
SelectItem,
|
||||
SelectTrigger,
|
||||
SelectValue
|
||||
} from '@/components/ui/select'
|
||||
import { getAgentList, sendChatStream } from '@/api/agent'
|
||||
import StyleSelector from '@/components/StyleSelector.vue'
|
||||
import { sendChatStream } from '@/api/agent'
|
||||
|
||||
// Props
|
||||
const props = defineProps<{
|
||||
@@ -111,8 +93,6 @@ const emit = defineEmits<{
|
||||
}>()
|
||||
|
||||
// 状态
|
||||
const agentList = ref<any[]>([])
|
||||
const loadingAgents = ref(false)
|
||||
const selectedAgentId = ref<number | null>(null)
|
||||
const theme = ref('')
|
||||
const generatedText = ref('')
|
||||
@@ -125,25 +105,6 @@ const canGenerate = computed(() => {
|
||||
return selectedAgentId.value && theme.value.trim().length > 0
|
||||
})
|
||||
|
||||
// 获取智能体列表
|
||||
const fetchAgents = async () => {
|
||||
loadingAgents.value = true
|
||||
try {
|
||||
const res = await getAgentList()
|
||||
if (res.code === 0 && res.data) {
|
||||
agentList.value = res.data
|
||||
// 默认选中第一个
|
||||
if (res.data.length > 0 && !selectedAgentId.value) {
|
||||
selectedAgentId.value = res.data[0].id
|
||||
}
|
||||
}
|
||||
} catch (error) {
|
||||
console.error('获取智能体列表失败:', error)
|
||||
} finally {
|
||||
loadingAgents.value = false
|
||||
}
|
||||
}
|
||||
|
||||
// 更新气泡位置
|
||||
const updatePosition = () => {
|
||||
// 找到触发按钮
|
||||
@@ -179,9 +140,8 @@ const updatePosition = () => {
|
||||
const handleGenerate = async () => {
|
||||
if (!canGenerate.value || isGenerating.value) return
|
||||
|
||||
const selectedAgent = agentList.value.find(a => a.id === selectedAgentId.value)
|
||||
if (!selectedAgent) {
|
||||
toast.warning('请选择智能体')
|
||||
if (!selectedAgentId.value) {
|
||||
toast.warning('请选择风格')
|
||||
return
|
||||
}
|
||||
|
||||
@@ -198,7 +158,7 @@ const handleGenerate = async () => {
|
||||
|
||||
try {
|
||||
await sendChatStream({
|
||||
agentId: selectedAgent.id,
|
||||
agentId: selectedAgentId.value,
|
||||
content: prompt,
|
||||
ctrl: abortController.value,
|
||||
onMessage: (result: { event: string; content?: string; errorMessage?: string }) => {
|
||||
@@ -243,7 +203,6 @@ const handleClose = () => {
|
||||
// 监听 visible 变化
|
||||
watch(() => props.visible, (val) => {
|
||||
if (val) {
|
||||
fetchAgents()
|
||||
updatePosition()
|
||||
// 监听窗口大小变化
|
||||
window.addEventListener('resize', updatePosition)
|
||||
@@ -288,7 +247,7 @@ onUnmounted(() => {
|
||||
.popover-overlay {
|
||||
position: fixed;
|
||||
inset: 0;
|
||||
z-index: 1000;
|
||||
z-index: 40;
|
||||
}
|
||||
|
||||
// 气泡卡片
|
||||
@@ -298,7 +257,7 @@ onUnmounted(() => {
|
||||
box-shadow: 0 2px 8px rgba(0, 0, 0, 0.08), 0 0 1px rgba(0, 0, 0, 0.1);
|
||||
border: 1px solid @border-color;
|
||||
overflow: hidden;
|
||||
z-index: 1001;
|
||||
z-index: 40;
|
||||
}
|
||||
|
||||
// 头部
|
||||
@@ -358,45 +317,6 @@ onUnmounted(() => {
|
||||
margin-bottom: 6px;
|
||||
}
|
||||
|
||||
.agent-select {
|
||||
width: 100%;
|
||||
|
||||
:deep(.ant-select-selector) {
|
||||
background: @bg-hover !important;
|
||||
border-radius: 6px !important;
|
||||
padding: 4px 10px !important;
|
||||
min-height: 32px !important;
|
||||
display: flex !important;
|
||||
align-items: center !important;
|
||||
}
|
||||
|
||||
:deep(.ant-select-selection-item) {
|
||||
font-size: 13px;
|
||||
color: @text-primary;
|
||||
line-height: 24px !important;
|
||||
display: flex !important;
|
||||
align-items: center !important;
|
||||
}
|
||||
}
|
||||
|
||||
.agent-option {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
gap: 8px;
|
||||
}
|
||||
|
||||
.agent-icon {
|
||||
width: 18px;
|
||||
height: 18px;
|
||||
border-radius: 4px;
|
||||
object-fit: cover;
|
||||
}
|
||||
|
||||
.agent-name {
|
||||
font-size: 13px;
|
||||
color: @text-primary;
|
||||
}
|
||||
|
||||
.theme-input {
|
||||
width: 100%;
|
||||
height: 32px;
|
||||
|
||||
@@ -1,94 +1,94 @@
|
||||
<template>
|
||||
<div class="timeline-panel">
|
||||
<div class="timeline-header">
|
||||
<span class="timeline-title">时间轴对比</span>
|
||||
<span v-if="showDurations" class="duration-badge">
|
||||
人脸 {{ formatDuration(faceDurationMs) }}
|
||||
<div class="bg-[#fafbfc] border border-[#e5e7eb] rounded-md px-4 py-3 mt-2">
|
||||
<div class="flex justify-between items-center mb-2.5">
|
||||
<span class="text-[13px] font-semibold text-gray-800">时间轴对比</span>
|
||||
<span v-if="showDurations" class="flex items-center gap-1.5 text-[13px] text-gray-600 tabular-nums">
|
||||
<span class="flex items-center gap-[5px]">
|
||||
<span class="w-[7px] h-[7px] rounded-sm bg-blue-500"></span>
|
||||
视频 {{ formatDuration(faceDurationMs) }}
|
||||
</span>
|
||||
<template v-if="audioDurationMs > 0">
|
||||
<span class="divider"></span>
|
||||
音频 {{ formatDuration(audioDurationMs) }}
|
||||
<span class="text-gray-400 text-xs">/</span>
|
||||
<span class="flex items-center gap-[5px]">
|
||||
<span class="w-[7px] h-[7px] rounded-sm bg-emerald-500"></span>
|
||||
音频 {{ formatDuration(audioDurationMs) }}
|
||||
</span>
|
||||
</template>
|
||||
</span>
|
||||
</div>
|
||||
|
||||
<!-- 刻度尺 -->
|
||||
<div class="timeline-ruler">
|
||||
<div class="relative h-5 mb-1.5 ml-12">
|
||||
<div
|
||||
v-for="mark in rulerMarks"
|
||||
:key="mark.time"
|
||||
class="ruler-mark"
|
||||
class="absolute -translate-x-1/2 flex flex-col items-center"
|
||||
:style="{ left: mark.position + '%' }"
|
||||
>
|
||||
<span class="ruler-label">{{ mark.label }}</span>
|
||||
<span class="ruler-tick"></span>
|
||||
</div>
|
||||
|
||||
<!-- 音频结束位置标记 -->
|
||||
<div
|
||||
v-if="audioDurationMs > 0 && isExceed"
|
||||
class="audio-end-marker"
|
||||
:style="{ left: audioEndPosition + '%' }"
|
||||
>
|
||||
<span class="audio-marker-label">{{ (audioDurationMs / 1000).toFixed(1) }}s</span>
|
||||
<span class="audio-marker-line"></span>
|
||||
<span class="text-[11px] text-gray-400 leading-none mb-1">{{ mark.label }}</span>
|
||||
<span class="block w-px h-1 bg-[#e5e7eb]"></span>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- 轨道区域 -->
|
||||
<div class="timeline-tracks">
|
||||
<div class="flex flex-col gap-1.5">
|
||||
<!-- 视频轨道 -->
|
||||
<div class="track">
|
||||
<div class="track-info">
|
||||
<span class="track-icon">📹</span>
|
||||
<span class="track-label">视频</span>
|
||||
<div class="flex items-center gap-2">
|
||||
<div class="w-9 shrink-0">
|
||||
<span class="text-xs text-gray-600 font-medium">视频</span>
|
||||
</div>
|
||||
<div class="track-bar">
|
||||
<div class="flex-1 h-6 bg-[#f1f3f5] rounded relative overflow-hidden flex items-center">
|
||||
<div
|
||||
class="track-fill video-fill"
|
||||
class="h-full rounded flex items-center justify-center transition-[width] duration-300 min-w-[2px] bg-blue-500"
|
||||
:style="{ width: videoBarWidth + '%' }"
|
||||
>
|
||||
<span v-if="videoBarWidth > 15" class="track-time">{{ formatDuration(faceDurationMs) }}</span>
|
||||
<span v-if="videoBarWidth > 20" class="text-xs text-white font-medium tracking-wide">{{ formatDuration(faceDurationMs) }}</span>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- 音频轨道 -->
|
||||
<div class="track">
|
||||
<div class="track-info">
|
||||
<span class="track-icon">🎙️</span>
|
||||
<span class="track-label">音频</span>
|
||||
<div class="flex items-center gap-2">
|
||||
<div class="w-9 shrink-0">
|
||||
<span class="text-xs text-gray-600 font-medium">音频</span>
|
||||
</div>
|
||||
<div class="track-bar">
|
||||
<div class="flex-1 h-6 bg-[#f1f3f5] rounded relative overflow-hidden flex items-center">
|
||||
<div
|
||||
v-if="audioDurationMs > 0"
|
||||
class="track-fill audio-fill"
|
||||
:class="{ 'audio-exceed': isExceed }"
|
||||
class="h-full rounded flex items-center justify-center transition-[width] duration-300 min-w-[2px]"
|
||||
:class="isExceed ? 'bg-red-500' : 'bg-emerald-500'"
|
||||
:style="{ width: audioBarWidth + '%' }"
|
||||
>
|
||||
<span v-if="audioBarWidth > 15" class="track-time">{{ formatDuration(audioDurationMs) }}</span>
|
||||
<span v-if="audioBarWidth > 20" class="text-xs text-white font-medium tracking-wide">{{ formatDuration(audioDurationMs) }}</span>
|
||||
</div>
|
||||
<span v-else class="track-placeholder">等待生成音频</span>
|
||||
<span v-else class="text-xs text-gray-400 pl-2.5">等待生成音频</span>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- 校验错误提示 -->
|
||||
<div v-if="validationError" class="timeline-diff error">
|
||||
<Icon icon="lucide:x-circle" class="diff-icon" />
|
||||
<div v-if="validationError" class="flex items-center gap-1.5 mt-2.5 px-2.5 py-2 rounded text-xs font-medium text-red-500 bg-red-50 border border-red-200">
|
||||
<Icon icon="lucide:x-circle" class="text-sm shrink-0" />
|
||||
<span>{{ validationError }}</span>
|
||||
</div>
|
||||
<!-- 时长差异提示 -->
|
||||
<div v-else-if="audioDurationMs > 0" class="timeline-diff" :class="diffStatus">
|
||||
<div v-else-if="audioDurationMs > 0" class="flex items-center gap-1.5 mt-2.5 px-2.5 py-2 rounded text-xs font-medium border border-transparent"
|
||||
:class="{
|
||||
'bg-[#f0fdf4] border-[#bbf7d0] text-emerald-600': diffStatus === 'match',
|
||||
'bg-red-50 border-red-200 text-red-500': diffStatus === 'exceed',
|
||||
'bg-amber-50 border-amber-200 text-amber-500': diffStatus === 'short',
|
||||
}"
|
||||
>
|
||||
<template v-if="diffStatus === 'match'">
|
||||
<Icon icon="lucide:check-circle" class="diff-icon" />
|
||||
<Icon icon="lucide:check-circle" class="text-sm shrink-0" />
|
||||
<span>时长匹配良好,可以生成</span>
|
||||
</template>
|
||||
<template v-else-if="diffStatus === 'exceed'">
|
||||
<Icon icon="lucide:alert-circle" class="diff-icon" />
|
||||
<Icon icon="lucide:alert-circle" class="text-sm shrink-0" />
|
||||
<span>音频超出 {{ formatDuration(diffMs) }},建议缩短文案</span>
|
||||
</template>
|
||||
<template v-else-if="diffStatus === 'short'">
|
||||
<Icon icon="lucide:info" class="diff-icon" />
|
||||
<Icon icon="lucide:info" class="text-sm shrink-0" />
|
||||
<span>音频较短,可适当增加文案</span>
|
||||
</template>
|
||||
</div>
|
||||
@@ -127,18 +127,17 @@ const audioBarWidth = computed(() =>
|
||||
Math.min(100, (props.audioDurationMs / maxDuration.value) * 100)
|
||||
)
|
||||
|
||||
const audioEndPosition = computed(() =>
|
||||
Math.min(100, (props.audioDurationMs / maxDuration.value) * 100)
|
||||
)
|
||||
|
||||
const isExceed = computed(() => props.audioDurationMs > props.faceDurationMs)
|
||||
|
||||
const diffMs = computed(() => Math.abs(props.audioDurationMs - props.faceDurationMs))
|
||||
|
||||
/** 时长差异阈值:3秒内视为匹配 */
|
||||
const MATCH_THRESHOLD_MS = 3000
|
||||
|
||||
const diffStatus = computed(() => {
|
||||
if (props.audioDurationMs === 0) return 'none'
|
||||
if (props.audioDurationMs > props.faceDurationMs) return 'exceed'
|
||||
if (props.audioDurationMs < props.faceDurationMs * 0.5) return 'short'
|
||||
if (props.faceDurationMs - props.audioDurationMs > MATCH_THRESHOLD_MS) return 'short'
|
||||
return 'match'
|
||||
})
|
||||
|
||||
@@ -175,235 +174,3 @@ function calculateInterval(duration: number): number {
|
||||
|
||||
const formatDuration = formatDurationMs
|
||||
</script>
|
||||
|
||||
<style scoped lang="less">
|
||||
// 蓝紫主题配色 - 与主页面协调
|
||||
@text-primary: #1e293b;
|
||||
@text-secondary: #64748b;
|
||||
@text-tertiary: #94a3b8;
|
||||
@bg-subtle: rgba(59, 130, 246, 0.04);
|
||||
@bg-hover: rgba(59, 130, 246, 0.08);
|
||||
@border-light: rgba(59, 130, 246, 0.1);
|
||||
@border-medium: rgba(59, 130, 246, 0.15);
|
||||
@accent-blue: #3b82f6;
|
||||
@accent-purple: #8b5cf6;
|
||||
@accent-green: #10b981;
|
||||
@accent-red: #ef4444;
|
||||
@accent-orange: #f59e0b;
|
||||
|
||||
.timeline-panel {
|
||||
background: @bg-subtle;
|
||||
border-radius: 10px;
|
||||
padding: 14px 18px;
|
||||
margin-top: 8px;
|
||||
}
|
||||
|
||||
.timeline-header {
|
||||
display: flex;
|
||||
justify-content: space-between;
|
||||
align-items: center;
|
||||
margin-bottom: 16px;
|
||||
}
|
||||
|
||||
.timeline-title {
|
||||
font-size: 12px;
|
||||
font-weight: 600;
|
||||
color: @text-secondary;
|
||||
text-transform: uppercase;
|
||||
letter-spacing: 0.5px;
|
||||
}
|
||||
|
||||
.duration-badge {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
gap: 8px;
|
||||
font-size: 12px;
|
||||
color: @text-tertiary;
|
||||
|
||||
.divider {
|
||||
width: 4px;
|
||||
height: 4px;
|
||||
background: @border-medium;
|
||||
border-radius: 50%;
|
||||
}
|
||||
}
|
||||
|
||||
// 刻度尺
|
||||
.timeline-ruler {
|
||||
position: relative;
|
||||
height: 18px;
|
||||
margin-bottom: 10px;
|
||||
margin-left: 80px;
|
||||
}
|
||||
|
||||
.ruler-mark {
|
||||
position: absolute;
|
||||
transform: translateX(-50%);
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
align-items: center;
|
||||
}
|
||||
|
||||
.ruler-label {
|
||||
font-size: 10px;
|
||||
color: @text-tertiary;
|
||||
margin-bottom: 2px;
|
||||
}
|
||||
|
||||
.ruler-tick {
|
||||
display: block;
|
||||
width: 1px;
|
||||
height: 4px;
|
||||
background: @border-medium;
|
||||
}
|
||||
|
||||
// 音频结束位置标记
|
||||
.audio-end-marker {
|
||||
position: absolute;
|
||||
transform: translateX(-50%);
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
align-items: center;
|
||||
z-index: 10;
|
||||
top: 0;
|
||||
}
|
||||
|
||||
.audio-marker-label {
|
||||
font-size: 9px;
|
||||
font-weight: 600;
|
||||
color: @accent-red;
|
||||
background: rgba(235, 87, 87, 0.1);
|
||||
padding: 1px 5px;
|
||||
border-radius: 3px;
|
||||
white-space: nowrap;
|
||||
margin-bottom: 2px;
|
||||
}
|
||||
|
||||
.audio-marker-line {
|
||||
width: 1px;
|
||||
height: 6px;
|
||||
background: @accent-red;
|
||||
}
|
||||
|
||||
// 轨道区域
|
||||
.timeline-tracks {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 8px;
|
||||
}
|
||||
|
||||
.track {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
gap: 12px;
|
||||
}
|
||||
|
||||
.track-info {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
gap: 6px;
|
||||
width: 68px;
|
||||
flex-shrink: 0;
|
||||
}
|
||||
|
||||
.track-icon {
|
||||
font-size: 14px;
|
||||
line-height: 1;
|
||||
}
|
||||
|
||||
.track-label {
|
||||
font-size: 12px;
|
||||
color: @text-secondary;
|
||||
font-weight: 500;
|
||||
}
|
||||
|
||||
.track-bar {
|
||||
flex: 1;
|
||||
height: 22px;
|
||||
background: rgba(55, 53, 47, 0.06);
|
||||
border-radius: 4px;
|
||||
position: relative;
|
||||
overflow: hidden;
|
||||
display: flex;
|
||||
align-items: center;
|
||||
}
|
||||
|
||||
.track-fill {
|
||||
height: 100%;
|
||||
border-radius: 4px;
|
||||
display: flex;
|
||||
align-items: center;
|
||||
justify-content: center;
|
||||
transition: width 0.4s cubic-bezier(0.4, 0, 0.2, 1);
|
||||
position: relative;
|
||||
}
|
||||
|
||||
.track-time {
|
||||
font-size: 10px;
|
||||
color: rgba(255, 255, 255, 0.95);
|
||||
font-weight: 600;
|
||||
text-shadow: 0 1px 2px rgba(0, 0, 0, 0.15);
|
||||
letter-spacing: 0.3px;
|
||||
}
|
||||
|
||||
.track-placeholder {
|
||||
font-size: 11px;
|
||||
color: @text-tertiary;
|
||||
padding-left: 14px;
|
||||
}
|
||||
|
||||
.video-fill {
|
||||
background: linear-gradient(90deg, @accent-blue 0%, @accent-purple 100%);
|
||||
}
|
||||
|
||||
.audio-fill {
|
||||
background: linear-gradient(90deg, @accent-green 0%, #059669 100%);
|
||||
|
||||
&.audio-exceed {
|
||||
background: linear-gradient(90deg, @accent-red 0%, #dc2626 100%);
|
||||
animation: pulse-warning 2s ease-in-out infinite;
|
||||
}
|
||||
}
|
||||
|
||||
@keyframes pulse-warning {
|
||||
0%, 100% { opacity: 1; }
|
||||
50% { opacity: 0.75; }
|
||||
}
|
||||
|
||||
// 差异提示
|
||||
.timeline-diff {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
gap: 8px;
|
||||
margin-top: 12px;
|
||||
padding: 10px 14px;
|
||||
border-radius: 8px;
|
||||
font-size: 12px;
|
||||
font-weight: 500;
|
||||
|
||||
.diff-icon {
|
||||
font-size: 14px;
|
||||
flex-shrink: 0;
|
||||
}
|
||||
|
||||
&.match {
|
||||
background: rgba(16, 185, 129, 0.08);
|
||||
color: @accent-green;
|
||||
}
|
||||
|
||||
&.exceed {
|
||||
background: rgba(239, 68, 68, 0.08);
|
||||
color: @accent-red;
|
||||
}
|
||||
|
||||
&.short {
|
||||
background: rgba(245, 158, 11, 0.08);
|
||||
color: @accent-orange;
|
||||
}
|
||||
|
||||
&.error {
|
||||
background: rgba(239, 68, 68, 0.12);
|
||||
color: @accent-red;
|
||||
}
|
||||
}
|
||||
</style>
|
||||
|
||||
@@ -70,6 +70,9 @@ export const useDigitalHumanStore = defineStore('digitalHuman', () => {
|
||||
/** 视频预览URL */
|
||||
const videoPreviewUrl = ref('')
|
||||
|
||||
/** 素材库视频的签名URL(用于识别API,不用于播放) */
|
||||
let signedVideoUrl = ''
|
||||
|
||||
/** 错误信息 */
|
||||
const error = ref('')
|
||||
|
||||
@@ -156,7 +159,7 @@ export const useDigitalHumanStore = defineStore('digitalHuman', () => {
|
||||
if (!timeline.value || timeline.value.audioDurationMs === 0) return 'none'
|
||||
const { videoDurationMs, audioDurationMs } = timeline.value
|
||||
if (audioDurationMs > videoDurationMs) return 'exceed'
|
||||
if (audioDurationMs < videoDurationMs * 0.3) return 'too-short'
|
||||
if (videoDurationMs - audioDurationMs > 3000) return 'too-short'
|
||||
return 'match'
|
||||
})
|
||||
|
||||
@@ -278,7 +281,19 @@ export const useDigitalHumanStore = defineStore('digitalHuman', () => {
|
||||
if (urlRes.code !== 0 || !urlRes.data) {
|
||||
throw new Error(urlRes.msg || '获取播放链接失败')
|
||||
}
|
||||
videoPreviewUrl.value = urlRes.data
|
||||
// 保存签名URL用于识别API
|
||||
signedVideoUrl = urlRes.data
|
||||
|
||||
// 下载视频到本地生成blob URL,确保浏览器能正常播放
|
||||
videoStep.value = 'uploading'
|
||||
const response = await fetch(urlRes.data)
|
||||
if (!response.ok) throw new Error('视频下载失败')
|
||||
const blob = await response.blob()
|
||||
// 释放旧的blob URL
|
||||
if (videoPreviewUrl.value?.startsWith('blob:')) {
|
||||
URL.revokeObjectURL(videoPreviewUrl.value)
|
||||
}
|
||||
videoPreviewUrl.value = URL.createObjectURL(blob)
|
||||
} catch (err: any) {
|
||||
videoStep.value = 'error'
|
||||
error.value = err.message || '获取播放链接失败'
|
||||
@@ -350,8 +365,8 @@ export const useDigitalHumanStore = defineStore('digitalHuman', () => {
|
||||
|
||||
/** 识别已存在的视频 */
|
||||
async function recognizeExistingVideo(video: Video): Promise<IdentifyData> {
|
||||
// 使用已获取的带签名预览URL
|
||||
return performFaceRecognition(video.id, videoPreviewUrl.value, false)
|
||||
// 使用签名URL调用识别API(blob URL不可被外部API访问)
|
||||
return performFaceRecognition(video.id, signedVideoUrl, false)
|
||||
}
|
||||
|
||||
/** 执行人脸识别 */
|
||||
@@ -564,6 +579,7 @@ export const useDigitalHumanStore = defineStore('digitalHuman', () => {
|
||||
videoFile.value = null
|
||||
selectedVideo.value = null
|
||||
videoPreviewUrl.value = ''
|
||||
signedVideoUrl = ''
|
||||
videoSelectorVisible.value = false
|
||||
|
||||
resetProcess()
|
||||
|
||||
@@ -52,6 +52,18 @@ public interface FileApi {
|
||||
String presignGetUrl(@NotEmpty(message = "URL 不能为空") String url,
|
||||
Integer expirationSeconds);
|
||||
|
||||
/**
|
||||
* 生成文件预签名地址(带 Content-Type),用于读取
|
||||
*
|
||||
* @param url 完整的文件访问地址
|
||||
* @param expirationSeconds 访问有效期,单位秒
|
||||
* @param contentType 响应的 Content-Type,为 null 时不设置
|
||||
* @return 文件预签名地址
|
||||
*/
|
||||
String presignGetUrl(@NotEmpty(message = "URL 不能为空") String url,
|
||||
Integer expirationSeconds,
|
||||
String contentType);
|
||||
|
||||
/**
|
||||
* 生成文件预签名地址(带 OSS 处理参数),用于读取
|
||||
* 用于阿里云 OSS 视频截帧等图片处理场景
|
||||
|
||||
@@ -31,7 +31,12 @@ public class FileApiImpl implements FileApi {
|
||||
|
||||
@Override
|
||||
public String presignGetUrl(String url, Integer expirationSeconds) {
|
||||
return fileService.presignGetUrl(url, expirationSeconds);
|
||||
return presignGetUrl(url, expirationSeconds, null);
|
||||
}
|
||||
|
||||
@Override
|
||||
public String presignGetUrl(String url, Integer expirationSeconds, String contentType) {
|
||||
return fileService.presignGetUrl(url, expirationSeconds, contentType);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
@@ -71,6 +71,18 @@ public interface FileClient {
|
||||
* @return 文件预签名地址
|
||||
*/
|
||||
default String presignGetUrl(String url, Integer expirationSeconds) {
|
||||
return presignGetUrl(url, expirationSeconds, null);
|
||||
}
|
||||
|
||||
/**
|
||||
* 生成文件预签名地址(带 Content-Type),用于读取
|
||||
*
|
||||
* @param url 完整的文件访问地址
|
||||
* @param expirationSeconds 访问有效期,单位秒
|
||||
* @param contentType 响应的 Content-Type,为 null 时不设置
|
||||
* @return 文件预签名地址
|
||||
*/
|
||||
default String presignGetUrl(String url, Integer expirationSeconds, String contentType) {
|
||||
throw new UnsupportedOperationException("不支持的操作");
|
||||
}
|
||||
|
||||
|
||||
@@ -200,12 +200,19 @@ public class S3FileClient extends AbstractFileClient<S3FileClientConfig> {
|
||||
}
|
||||
|
||||
@Override
|
||||
public String presignGetUrl(String url, Integer expirationSeconds) {
|
||||
return presignGetUrlWithProcess(url, expirationSeconds, null);
|
||||
public String presignGetUrl(String url, Integer expirationSeconds, String contentType) {
|
||||
return presignGetUrlWithProcess(url, expirationSeconds, null, contentType);
|
||||
}
|
||||
|
||||
@Override
|
||||
public String presignGetUrlWithProcess(String url, Integer expirationSeconds, String processParam) {
|
||||
return presignGetUrlWithProcess(url, expirationSeconds, processParam, null);
|
||||
}
|
||||
|
||||
/**
|
||||
* 生成文件预签名地址(带 OSS 处理参数和 Content-Type),用于读取
|
||||
*/
|
||||
private String presignGetUrlWithProcess(String url, Integer expirationSeconds, String processParam, String contentType) {
|
||||
// 1. 将 url 转换为 path(支持 CDN 域名和 OSS 原始域名)
|
||||
String path = extractPathFromUrl(url);
|
||||
String decodedPath = URLUtil.decode(path, StandardCharsets.UTF_8);
|
||||
@@ -213,11 +220,17 @@ public class S3FileClient extends AbstractFileClient<S3FileClientConfig> {
|
||||
// 2. 公开访问:无需签名,直接拼接参数
|
||||
if (!BooleanUtil.isFalse(config.getEnablePublicAccess())) {
|
||||
String encodedPath = UriUtils.encodePath(decodedPath, StandardCharsets.UTF_8);
|
||||
String resultUrl = config.getDomain() + "/" + encodedPath;
|
||||
StringBuilder resultUrl = new StringBuilder(config.getDomain()).append("/").append(encodedPath);
|
||||
char separator = '?';
|
||||
if (StrUtil.isNotBlank(processParam)) {
|
||||
resultUrl = resultUrl + "?x-oss-process=" + processParam;
|
||||
resultUrl.append(separator).append("x-oss-process=").append(processParam);
|
||||
separator = '&';
|
||||
}
|
||||
return resultUrl;
|
||||
if (StrUtil.isNotBlank(contentType)) {
|
||||
resultUrl.append(separator).append("response-content-type=").append(
|
||||
URLUtil.encode(contentType, StandardCharsets.UTF_8));
|
||||
}
|
||||
return resultUrl.toString();
|
||||
}
|
||||
|
||||
// 3. 私有访问:生成预签名 URL(需要将处理参数包含在签名中)
|
||||
@@ -229,10 +242,14 @@ public class S3FileClient extends AbstractFileClient<S3FileClientConfig> {
|
||||
com.aliyun.oss.model.GeneratePresignedUrlRequest request =
|
||||
new com.aliyun.oss.model.GeneratePresignedUrlRequest(config.getBucket(), decodedPath, HttpMethod.GET);
|
||||
request.setExpiration(expirationDate);
|
||||
// 关键:将 x-oss-process 参数包含在签名中
|
||||
// 将 x-oss-process 参数包含在签名中
|
||||
if (StrUtil.isNotBlank(processParam)) {
|
||||
request.addQueryParameter("x-oss-process", processParam);
|
||||
}
|
||||
// 设置 response-content-type,确保浏览器能正确渲染
|
||||
if (StrUtil.isNotBlank(contentType)) {
|
||||
request.addQueryParameter("response-content-type", contentType);
|
||||
}
|
||||
signedUrl = aliyunOssClient.generatePresignedUrl(request).toString();
|
||||
} else {
|
||||
// 非阿里云不支持 OSS 处理参数,直接返回普通预签名 URL
|
||||
|
||||
@@ -54,6 +54,16 @@ public interface FileService {
|
||||
*/
|
||||
String presignGetUrl(String url, Integer expirationSeconds);
|
||||
|
||||
/**
|
||||
* 生成文件预签名地址(带 Content-Type),用于读取
|
||||
*
|
||||
* @param url 完整的文件访问地址
|
||||
* @param expirationSeconds 访问有效期,单位秒
|
||||
* @param contentType 响应的 Content-Type,为 null 时不设置
|
||||
* @return 文件预签名地址
|
||||
*/
|
||||
String presignGetUrl(String url, Integer expirationSeconds, String contentType);
|
||||
|
||||
/**
|
||||
* 生成文件预签名地址(带 OSS 处理参数),用于读取
|
||||
* 用于阿里云 OSS 视频截帧等图片处理场景
|
||||
|
||||
@@ -142,8 +142,13 @@ public class FileServiceImpl implements FileService {
|
||||
|
||||
@Override
|
||||
public String presignGetUrl(String url, Integer expirationSeconds) {
|
||||
return presignGetUrl(url, expirationSeconds, null);
|
||||
}
|
||||
|
||||
@Override
|
||||
public String presignGetUrl(String url, Integer expirationSeconds, String contentType) {
|
||||
FileClient fileClient = fileConfigService.getMasterFileClient();
|
||||
return fileClient.presignGetUrl(url, expirationSeconds);
|
||||
return fileClient.presignGetUrl(url, expirationSeconds, contentType);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
@@ -68,29 +68,35 @@ public class AppDifyController {
|
||||
}
|
||||
|
||||
@GetMapping("/conversations")
|
||||
@Operation(summary = "获取会话列表")
|
||||
@Operation(summary = "获取会话列表(合并 pro + standard)")
|
||||
@Parameter(name = "agentId", description = "智能体ID", required = true)
|
||||
@Parameter(name = "lastId", description = "上一页最后一条记录ID")
|
||||
@Parameter(name = "source", description = "来源类型:agent-智能体 prompt-自建风格")
|
||||
@Parameter(name = "cursor", description = "复合游标(首页不传)")
|
||||
@Parameter(name = "limit", description = "返回条数,默认20")
|
||||
public CommonResult<DifyConversationListRespVO> getConversations(
|
||||
@RequestParam("agentId") Long agentId,
|
||||
@RequestParam(value = "lastId", required = false) String lastId,
|
||||
@RequestParam(value = "source", required = false, defaultValue = "agent") String source,
|
||||
@RequestParam(value = "cursor", required = false) String cursor,
|
||||
@RequestParam(value = "limit", required = false) Integer limit) {
|
||||
return CommonResult.success(difyService.getConversations(agentId, getCurrentUserId(), lastId, limit));
|
||||
return CommonResult.success(difyService.getConversations(agentId, source, getCurrentUserId(), cursor, limit));
|
||||
}
|
||||
|
||||
@GetMapping("/messages")
|
||||
@Operation(summary = "获取会话历史消息")
|
||||
@Operation(summary = "获取会话历史消息(自动定位 App)")
|
||||
@Parameter(name = "agentId", description = "智能体ID", required = true)
|
||||
@Parameter(name = "source", description = "来源类型:agent-智能体 prompt-自建风格")
|
||||
@Parameter(name = "conversationId", description = "会话ID", required = true)
|
||||
@Parameter(name = "appSource", description = "来源应用标识:pro/standard")
|
||||
@Parameter(name = "firstId", description = "当前页第一条记录ID")
|
||||
@Parameter(name = "limit", description = "返回条数,默认20")
|
||||
public CommonResult<DifyMessageListRespVO> getMessages(
|
||||
@RequestParam("agentId") Long agentId,
|
||||
@RequestParam(value = "source", required = false, defaultValue = "agent") String source,
|
||||
@RequestParam("conversationId") String conversationId,
|
||||
@RequestParam(value = "appSource", required = false) String appSource,
|
||||
@RequestParam(value = "firstId", required = false) String firstId,
|
||||
@RequestParam(value = "limit", required = false) Integer limit) {
|
||||
return CommonResult.success(difyService.getMessages(agentId, conversationId, getCurrentUserId(), firstId, limit));
|
||||
return CommonResult.success(difyService.getMessages(agentId, source, conversationId, appSource, getCurrentUserId(), firstId, limit));
|
||||
}
|
||||
|
||||
private String getCurrentUserId() {
|
||||
|
||||
@@ -53,26 +53,29 @@ public interface DifyService {
|
||||
Flux<DifyChatRespVO> promptAnalysisStream(PromptAnalysisReqVO reqVO, String userId);
|
||||
|
||||
/**
|
||||
* 获取会话列表
|
||||
* 获取会话列表(合并 pro + standard 两个 Dify App 的会话)
|
||||
*
|
||||
* @param agentId 智能体ID
|
||||
* @param source 来源类型(agent/prompt)
|
||||
* @param userId 用户ID
|
||||
* @param lastId 上一页最后一条记录ID
|
||||
* @param cursor 复合游标(Base64 编码,首页传 null)
|
||||
* @param limit 返回条数
|
||||
* @return 会话列表
|
||||
*/
|
||||
DifyConversationListRespVO getConversations(Long agentId, String userId, String lastId, Integer limit);
|
||||
DifyConversationListRespVO getConversations(Long agentId, String source, String userId, String cursor, Integer limit);
|
||||
|
||||
/**
|
||||
* 获取会话历史消息
|
||||
* 获取会话历史消息(自动定位 pro/standard App)
|
||||
*
|
||||
* @param agentId 智能体ID
|
||||
* @param source 来源类型(agent/prompt)
|
||||
* @param conversationId 会话ID
|
||||
* @param appSource 来源应用标识(pro/standard),用于选择 API Key
|
||||
* @param userId 用户ID
|
||||
* @param firstId 当前页第一条记录ID
|
||||
* @param limit 返回条数
|
||||
* @return 消息列表
|
||||
*/
|
||||
DifyMessageListRespVO getMessages(Long agentId, String conversationId, String userId, String firstId, Integer limit);
|
||||
DifyMessageListRespVO getMessages(Long agentId, String source, String conversationId, String appSource, String userId, String firstId, Integer limit);
|
||||
|
||||
}
|
||||
|
||||
@@ -6,6 +6,7 @@ import cn.iocoder.yudao.module.tik.dify.vo.DifyChatReqVO;
|
||||
import cn.iocoder.yudao.module.tik.dify.vo.PromptAnalysisReqVO;
|
||||
import cn.iocoder.yudao.module.tik.dify.vo.DifyChatRespVO;
|
||||
import cn.iocoder.yudao.module.tik.dify.vo.DifyConversationListRespVO;
|
||||
import cn.iocoder.yudao.module.tik.dify.vo.DifyConversationRespVO;
|
||||
import cn.iocoder.yudao.module.tik.dify.vo.DifyMessageListRespVO;
|
||||
import cn.iocoder.yudao.module.tik.dify.vo.ForecastRewriteReqVO;
|
||||
import cn.iocoder.yudao.module.tik.enums.AiModelTypeEnum;
|
||||
@@ -21,7 +22,13 @@ import org.springframework.validation.annotation.Validated;
|
||||
import reactor.core.publisher.Flux;
|
||||
import reactor.core.publisher.Mono;
|
||||
|
||||
import cn.iocoder.yudao.framework.common.util.json.JsonUtils;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.Base64;
|
||||
import java.util.Collections;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.concurrent.atomic.AtomicLong;
|
||||
import java.util.concurrent.atomic.AtomicReference;
|
||||
@@ -50,13 +57,22 @@ public class DifyServiceImpl implements DifyService {
|
||||
AtomicLong pendingRecordId = new AtomicLong();
|
||||
AtomicReference<String> conversationIdRef = new AtomicReference<>(reqVO.getConversationId());
|
||||
AtomicReference<DifyChatRespVO> tokenUsageRef = new AtomicReference<>();
|
||||
String difyUserId = "user-" + userId + "-agent-" + reqVO.getAgentId();
|
||||
String difyUserId = buildDifyUserId(userId, reqVO.getSource(), reqVO.getAgentId());
|
||||
String logPrefix = "chatStream";
|
||||
|
||||
return Mono.fromCallable(() -> {
|
||||
AiAgentDO agent = aiAgentService.getAiAgent(reqVO.getAgentId());
|
||||
if (agent == null) {
|
||||
throw new RuntimeException("智能体不存在");
|
||||
// 解析系统提示词:优先使用自定义提示词,否则从智能体获取
|
||||
String systemPrompt;
|
||||
if (reqVO.getCustomSystemPrompt() != null && !reqVO.getCustomSystemPrompt().isEmpty()) {
|
||||
systemPrompt = reqVO.getCustomSystemPrompt();
|
||||
} else if (reqVO.getAgentId() != null) {
|
||||
AiAgentDO agent = aiAgentService.getAiAgent(reqVO.getAgentId());
|
||||
if (agent == null) {
|
||||
throw new RuntimeException("智能体不存在");
|
||||
}
|
||||
systemPrompt = agent.getSystemPrompt();
|
||||
} else {
|
||||
throw new RuntimeException("必须提供 agentId 或 customSystemPrompt");
|
||||
}
|
||||
|
||||
AiModelTypeEnum modelTypeEnum = "standard".equals(reqVO.getModelMode())
|
||||
@@ -66,12 +82,15 @@ public class DifyServiceImpl implements DifyService {
|
||||
AiPlatformEnum.DIFY.getPlatform(), modelTypeEnum.getModelCode());
|
||||
|
||||
pointsService.checkPoints(userId, config.getConsumePoints());
|
||||
String serviceRef = reqVO.getAgentId() != null
|
||||
? reqVO.getAgentId().toString()
|
||||
: "custom-prompt";
|
||||
Long recordId = pointsService.createPendingDeduct(
|
||||
userId, config.getConsumePoints(), "dify_chat",
|
||||
reqVO.getAgentId().toString(), config.getServiceCode());
|
||||
serviceRef, config.getServiceCode());
|
||||
pendingRecordId.set(recordId);
|
||||
|
||||
return new DifyChatContext(agent.getSystemPrompt(), config.getApiKey(), config.getConsumePoints());
|
||||
return new DifyChatContext(systemPrompt, config.getApiKey(), config.getConsumePoints());
|
||||
})
|
||||
.flatMapMany(context -> difyClient.chatStream(
|
||||
context.apiKey(), reqVO.getContent(), context.systemPrompt(),
|
||||
@@ -366,55 +385,169 @@ public class DifyServiceImpl implements DifyService {
|
||||
}
|
||||
|
||||
@Override
|
||||
public DifyConversationListRespVO getConversations(Long agentId, String userId, String lastId, Integer limit) {
|
||||
// 获取智能体配置
|
||||
AiAgentDO agent = aiAgentService.getAiAgent(agentId);
|
||||
if (agent == null) {
|
||||
throw new RuntimeException("智能体不存在");
|
||||
public DifyConversationListRespVO getConversations(Long agentId, String source, String userId, String cursor, Integer limit) {
|
||||
if (limit == null || limit <= 0) {
|
||||
limit = 20;
|
||||
}
|
||||
|
||||
// 获取积分配置(使用标准模式的 API Key)
|
||||
AiServiceConfigDO config = pointsService.getConfig(
|
||||
AiPlatformEnum.DIFY.getPlatform(),
|
||||
AiModelTypeEnum.DIFY_WRITING_STANDARD.getModelCode());
|
||||
AiServiceConfigDO proConfig = getDifyConfig(false);
|
||||
AiServiceConfigDO standardConfig = getDifyConfig(true);
|
||||
|
||||
// Dify 用户标识(按 agentId 隔离会话)
|
||||
String difyUserId = "user-" + userId + "-agent-" + agentId;
|
||||
String difyUserId = buildDifyUserId(userId, source, agentId);
|
||||
|
||||
DifyConversationListRespVO result = difyClient.getConversations(config.getApiKey(), difyUserId, lastId, limit);
|
||||
String proLastId = null;
|
||||
String standardLastId = null;
|
||||
if (cursor != null && !cursor.isEmpty()) {
|
||||
try {
|
||||
String json = new String(Base64.getDecoder().decode(cursor));
|
||||
com.fasterxml.jackson.databind.JsonNode node = JsonUtils.parseTree(json);
|
||||
proLastId = node.has("pro") ? node.get("pro").asText(null) : null;
|
||||
standardLastId = node.has("standard") ? node.get("standard").asText(null) : null;
|
||||
} catch (Exception e) {
|
||||
log.warn("[getConversations] 游标解析失败,从头开始: {}", cursor, e);
|
||||
}
|
||||
}
|
||||
|
||||
List<DifyConversationRespVO> proList = Collections.emptyList();
|
||||
List<DifyConversationRespVO> standardList = Collections.emptyList();
|
||||
boolean proHasMore = false;
|
||||
boolean standardHasMore = false;
|
||||
|
||||
try {
|
||||
DifyConversationListRespVO proResult = difyClient.getConversations(
|
||||
proConfig.getApiKey(), difyUserId, proLastId, limit);
|
||||
if (proResult != null && proResult.getData() != null) {
|
||||
proList = proResult.getData();
|
||||
proList.forEach(c -> c.setAppSource("pro"));
|
||||
proHasMore = proResult.getHasMore() != null && proResult.getHasMore();
|
||||
}
|
||||
} catch (Exception e) {
|
||||
log.warn("[getConversations] 查询 Pro 会话列表失败", e);
|
||||
}
|
||||
|
||||
try {
|
||||
DifyConversationListRespVO standardResult = difyClient.getConversations(
|
||||
standardConfig.getApiKey(), difyUserId, standardLastId, limit);
|
||||
if (standardResult != null && standardResult.getData() != null) {
|
||||
standardList = standardResult.getData();
|
||||
standardList.forEach(c -> c.setAppSource("standard"));
|
||||
standardHasMore = standardResult.getHasMore() != null && standardResult.getHasMore();
|
||||
}
|
||||
} catch (Exception e) {
|
||||
log.warn("[getConversations] 查询 Standard 会话列表失败", e);
|
||||
}
|
||||
|
||||
// 合并两个列表,按 updatedAt 降序排序,截取 limit 条
|
||||
List<DifyConversationRespVO> merged = new ArrayList<>();
|
||||
merged.addAll(proList);
|
||||
merged.addAll(standardList);
|
||||
merged.sort((a, b) -> {
|
||||
long timeA = a.getUpdatedAt() != null ? a.getUpdatedAt() : (a.getCreatedAt() != null ? a.getCreatedAt() : 0);
|
||||
long timeB = b.getUpdatedAt() != null ? b.getUpdatedAt() : (b.getCreatedAt() != null ? b.getCreatedAt() : 0);
|
||||
return Long.compare(timeB, timeA); // 降序
|
||||
});
|
||||
|
||||
// 判断是否有更多数据
|
||||
boolean hasMore = proHasMore || standardHasMore;
|
||||
|
||||
List<DifyConversationRespVO> pageData;
|
||||
if (merged.size() > limit) {
|
||||
pageData = new ArrayList<>(merged.subList(0, limit));
|
||||
hasMore = true;
|
||||
} else {
|
||||
pageData = merged;
|
||||
}
|
||||
|
||||
// 过滤掉 inputs 中的敏感字段(如 sysPrompt)
|
||||
if (result != null && result.getData() != null) {
|
||||
result.getData().forEach(conv -> {
|
||||
if (conv.getInputs() != null) {
|
||||
conv.getInputs().remove("sysPrompt");
|
||||
}
|
||||
});
|
||||
}
|
||||
pageData.forEach(conv -> {
|
||||
if (conv.getInputs() != null) {
|
||||
conv.getInputs().remove("sysPrompt");
|
||||
}
|
||||
});
|
||||
|
||||
// 构建下一页游标:收集当前页中 pro 和 standard 的最后一条记录ID
|
||||
String nextCursor = buildNextCursor(pageData, proHasMore, standardHasMore);
|
||||
|
||||
DifyConversationListRespVO result = new DifyConversationListRespVO();
|
||||
result.setLimit(limit);
|
||||
result.setHasMore(hasMore);
|
||||
result.setData(pageData);
|
||||
result.setNextCursor(nextCursor);
|
||||
return result;
|
||||
}
|
||||
|
||||
@Override
|
||||
public DifyMessageListRespVO getMessages(Long agentId, String conversationId, String userId, String firstId, Integer limit) {
|
||||
// 获取智能体配置
|
||||
AiAgentDO agent = aiAgentService.getAiAgent(agentId);
|
||||
if (agent == null) {
|
||||
throw new RuntimeException("智能体不存在");
|
||||
/**
|
||||
* 构建下一页复合游标
|
||||
*/
|
||||
private String buildNextCursor(List<DifyConversationRespVO> pageData,
|
||||
boolean proHasMore, boolean standardHasMore) {
|
||||
if (pageData.isEmpty()) return null;
|
||||
|
||||
String proLastId = null;
|
||||
String standardLastId = null;
|
||||
|
||||
for (int i = pageData.size() - 1; i >= 0; i--) {
|
||||
DifyConversationRespVO conv = pageData.get(i);
|
||||
if ("pro".equals(conv.getAppSource()) && proLastId == null && proHasMore) {
|
||||
proLastId = conv.getId();
|
||||
}
|
||||
if ("standard".equals(conv.getAppSource()) && standardLastId == null && standardHasMore) {
|
||||
standardLastId = conv.getId();
|
||||
}
|
||||
if (proLastId != null && standardLastId != null) break;
|
||||
}
|
||||
|
||||
// 获取积分配置(使用标准模式的 API Key)
|
||||
AiServiceConfigDO config = pointsService.getConfig(
|
||||
AiPlatformEnum.DIFY.getPlatform(),
|
||||
AiModelTypeEnum.DIFY_WRITING_STANDARD.getModelCode());
|
||||
if (proLastId == null && standardLastId == null) return null;
|
||||
|
||||
// Dify 用户标识(按 agentId 隔离会话)
|
||||
String difyUserId = "user-" + userId + "-agent-" + agentId;
|
||||
try {
|
||||
Map<String, String> cursorMap = new HashMap<>();
|
||||
if (proLastId != null) cursorMap.put("pro", proLastId);
|
||||
if (standardLastId != null) cursorMap.put("standard", standardLastId);
|
||||
String json = JsonUtils.toJsonString(cursorMap);
|
||||
return Base64.getEncoder().encodeToString(json.getBytes());
|
||||
} catch (Exception e) {
|
||||
log.warn("[buildNextCursor] 构建游标失败", e);
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
DifyMessageListRespVO result = difyClient.getMessages(config.getApiKey(), conversationId, difyUserId, firstId, limit);
|
||||
@Override
|
||||
public DifyMessageListRespVO getMessages(Long agentId, String source, String conversationId,
|
||||
String appSource, String userId, String firstId, Integer limit) {
|
||||
String difyUserId = buildDifyUserId(userId, source, agentId);
|
||||
|
||||
boolean isStandard = "standard".equals(appSource);
|
||||
AiServiceConfigDO primaryConfig = getDifyConfig(isStandard);
|
||||
AiServiceConfigDO fallbackConfig = null;
|
||||
|
||||
DifyMessageListRespVO result = null;
|
||||
try {
|
||||
result = difyClient.getMessages(primaryConfig.getApiKey(), conversationId, difyUserId, firstId, limit);
|
||||
} catch (Exception e) {
|
||||
log.warn("[getMessages] 主 Key 查询失败,appSource: {}, 尝试降级", appSource, e);
|
||||
}
|
||||
|
||||
if (result == null || result.getData() == null || result.getData().isEmpty()) {
|
||||
fallbackConfig = getDifyConfig(!isStandard);
|
||||
try {
|
||||
DifyMessageListRespVO fallbackResult = difyClient.getMessages(
|
||||
fallbackConfig.getApiKey(), conversationId, difyUserId, firstId, limit);
|
||||
if (fallbackResult != null && fallbackResult.getData() != null && !fallbackResult.getData().isEmpty()) {
|
||||
result = fallbackResult;
|
||||
}
|
||||
} catch (Exception e) {
|
||||
log.warn("[getMessages] 降级 Key 查询也失败", e);
|
||||
}
|
||||
}
|
||||
|
||||
if (result == null) {
|
||||
result = new DifyMessageListRespVO();
|
||||
result.setData(Collections.emptyList());
|
||||
result.setHasMore(false);
|
||||
}
|
||||
|
||||
// 过滤掉 inputs 中的敏感字段(如 sysPrompt)
|
||||
if (result != null && result.getData() != null) {
|
||||
if (result.getData() != null) {
|
||||
result.getData().forEach(msg -> {
|
||||
if (msg.getInputs() != null) {
|
||||
msg.getInputs().remove("sysPrompt");
|
||||
@@ -425,4 +558,18 @@ public class DifyServiceImpl implements DifyService {
|
||||
return result;
|
||||
}
|
||||
|
||||
private static String resolveScope(String source) {
|
||||
return "prompt".equals(source) ? "prompt" : "agent";
|
||||
}
|
||||
|
||||
private String buildDifyUserId(String userId, String source, Long agentId) {
|
||||
return "user-" + userId + "-" + resolveScope(source) + "-" + agentId;
|
||||
}
|
||||
|
||||
private AiServiceConfigDO getDifyConfig(boolean standard) {
|
||||
return pointsService.getConfig(
|
||||
AiPlatformEnum.DIFY.getPlatform(),
|
||||
(standard ? AiModelTypeEnum.DIFY_WRITING_STANDARD : AiModelTypeEnum.DIFY_WRITING_PRO).getModelCode());
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -12,8 +12,7 @@ import lombok.Data;
|
||||
@Data
|
||||
public class DifyChatReqVO {
|
||||
|
||||
@Schema(description = "智能体ID", requiredMode = Schema.RequiredMode.REQUIRED)
|
||||
@NotNull(message = "智能体ID不能为空")
|
||||
@Schema(description = "智能体ID(使用 customSystemPrompt 时可不传)")
|
||||
private Long agentId;
|
||||
|
||||
@Schema(description = "用户输入内容", requiredMode = Schema.RequiredMode.REQUIRED)
|
||||
@@ -26,4 +25,10 @@ public class DifyChatReqVO {
|
||||
@Schema(description = "模型模式:pro-深度版 standard-标准版", example = "pro")
|
||||
private String modelMode = "pro";
|
||||
|
||||
@Schema(description = "自定义系统提示词(使用用户自建风格时传入)")
|
||||
private String customSystemPrompt;
|
||||
|
||||
@Schema(description = "来源类型:agent-智能体 prompt-自建风格", example = "agent")
|
||||
private String source;
|
||||
|
||||
}
|
||||
|
||||
@@ -1,5 +1,6 @@
|
||||
package cn.iocoder.yudao.module.tik.dify.vo;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import lombok.Data;
|
||||
|
||||
@@ -23,4 +24,8 @@ public class DifyConversationListRespVO {
|
||||
@Schema(description = "会话列表", requiredMode = Schema.RequiredMode.REQUIRED)
|
||||
private List<DifyConversationRespVO> data;
|
||||
|
||||
@Schema(description = "下一页游标(Base64 编码的复合游标)")
|
||||
@JsonProperty("next_cursor")
|
||||
private String nextCursor;
|
||||
|
||||
}
|
||||
|
||||
@@ -38,4 +38,8 @@ public class DifyConversationRespVO {
|
||||
@JsonProperty("updated_at")
|
||||
private Long updatedAt;
|
||||
|
||||
@Schema(description = "来源应用标识:pro/standard", example = "pro")
|
||||
@JsonProperty("app_source")
|
||||
private String appSource;
|
||||
|
||||
}
|
||||
|
||||
@@ -18,7 +18,7 @@ public class LatentsyncProperties {
|
||||
/**
|
||||
* 302AI API Key(可通过配置覆盖)
|
||||
*/
|
||||
private String apiKey = "sk-0IZJ2oo7VCkegFuF3JRsSRtyFUsIvLoHNK8OpulnlsStFN78";
|
||||
private String apiKey = "sk-0CdsUdm0z7JAFgnpyIOObYDvH5mUuCyv87dxbZlzW5yc6pPl";
|
||||
|
||||
/**
|
||||
* 默认海外网关
|
||||
|
||||
Reference in New Issue
Block a user