From 2e9321169716dc18f01abdc952bdb39370dbe558 Mon Sep 17 00:00:00 2001
From: shenaowei <450702724@qq.com>
Date: Wed, 25 Feb 2026 18:21:25 +0800
Subject: [PATCH] =?UTF-8?q?dify=E5=8E=86=E5=8F=B2=E8=AE=B0=E5=BD=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 frontend/app/web-gold/src/api/agent.js        |  31 +
 .../src/components/agents/ChatDrawer.vue      | 122 ++--
 .../src/components/agents/HistoryPanel.vue    | 595 ++++++++++++++++++
 .../app/web-gold/src/views/agents/Agents.vue  | 281 ++++++++-
 .../web-gold/src/views/kling/IdentifyFace.vue |   5 +-
 .../module/tik/dify/client/DifyClient.java    |  85 ++-
 .../dify/controller/AppDifyController.java    |  48 +-
 .../module/tik/dify/service/DifyService.java  |  25 +
 .../tik/dify/service/DifyServiceImpl.java     |  50 +-
 .../dify/vo/DifyConversationListRespVO.java   |  26 +
 .../tik/dify/vo/DifyConversationRespVO.java   |  41 ++
 .../tik/dify/vo/DifyMessageListRespVO.java    |  26 +
 .../module/tik/dify/vo/DifyMessageRespVO.java |  67 ++
 13 files changed, 1328 insertions(+), 74 deletions(-)
 create mode 100644 frontend/app/web-gold/src/components/agents/HistoryPanel.vue
 create mode 100644 yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/vo/DifyConversationListRespVO.java
 create mode 100644 yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/vo/DifyConversationRespVO.java
 create mode 100644 yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/vo/DifyMessageListRespVO.java
 create mode 100644 yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/vo/DifyMessageRespVO.java

diff --git a/frontend/app/web-gold/src/api/agent.js b/frontend/app/web-gold/src/api/agent.js
index 68a728786e..00f3c16742 100644
--- a/frontend/app/web-gold/src/api/agent.js
+++ b/frontend/app/web-gold/src/api/agent.js
@@ -85,3 +85,34 @@ export async function sendChatStream(options) {
     signal: ctrl ? ctrl.signal : undefined
   })
 }
+
+/**
+ * 获取会话列表
+ * @param {Object} params - 请求参数
+ * @param {number} params.agentId - 智能体ID
+ * @param {string} [params.lastId] - 上一页最后一条记录ID
+ * @param {number} [params.limit] - 返回条数，默认20
+ */
+export function getConversations(params) {
+  return request({
+    url: `${BASE_URL}/dify/conversations`,
+    method: 'get',
+    params
+  })
+}
+
+/**
+ * 获取会话历史消息
+ * @param {Object} params - 请求参数
+ * @param {number} params.agentId - 智能体ID
+ * @param {string} params.conversationId - 会话ID
+ * @param {string} [params.firstId] - 当前页第一条记录ID
+ * @param {number} [params.limit] - 返回条数，默认20
+ */
+export function getMessages(params) {
+  return request({
+    url: `${BASE_URL}/dify/messages`,
+    method: 'get',
+    params
+  })
+}
diff --git a/frontend/app/web-gold/src/components/agents/ChatDrawer.vue b/frontend/app/web-gold/src/components/agents/ChatDrawer.vue
index afb37f1e29..30db2da038 100644
--- a/frontend/app/web-gold/src/components/agents/ChatDrawer.vue
+++ b/frontend/app/web-gold/src/components/agents/ChatDrawer.vue
@@ -18,9 +18,14 @@
                 <span class="agent-category">{{ agent?.categoryName || '通用' }}</span>
               </div>
             </div>
-            <button class="close-btn" @click="handleClose">
-              <CloseOutlined />
-            </button>
+            <div class="header-actions">
+              <button class="history-btn" @click="openHistory" title="历史记录">
+                <HistoryOutlined />
+              </button>
+              <button class="close-btn" @click="handleClose">
+                <CloseOutlined />
+              </button>
+            </div>
           </header>
 
           <!-- Main Content -->
@@ -139,13 +144,20 @@
             <p class="footer-tip">按 Enter 发送，Shift + Enter 换行</p>
           </footer>
         </div>
+
+        <!-- History Drawer -->
+        <HistoryPanel
+          :visible="historyVisible"
+          :agent-id="agent?.id"
+          @close="closeHistory"
+        />
       </div>
     </transition>
   </teleport>
 </template>
 
 <script setup>
-import { ref, watch, nextTick, computed } from 'vue'
+import { ref, watch, nextTick } from 'vue'
 import {
   CloseOutlined,
   RobotOutlined,
@@ -154,11 +166,13 @@ import {
   ThunderboltFilled,
   EditOutlined,
   SendOutlined,
-  LoadingOutlined
+  LoadingOutlined,
+  HistoryOutlined
 } from '@ant-design/icons-vue'
 import { message, Modal } from 'ant-design-vue'
 import { sendChatStream } from '@/api/agent'
 import { copyToClipboard } from '@/utils/clipboard'
+import HistoryPanel from './HistoryPanel.vue'
 
 const props = defineProps({
   visible: { type: Boolean, default: false },
@@ -179,6 +193,9 @@ const textareaRef = ref(null)
 const resultBodyRef = ref(null)
 const abortController = ref(null)
 
+// History State
+const historyVisible = ref(false)
+
 // Methods
 const handleClose = (force = false) => {
   // 正在生成时，不允许关闭
@@ -234,42 +251,10 @@ const handleGenerate = async () => {
   isGenerating.value = true
   generatedContent.value = ''
   inputText.value = ''
-
   if (textareaRef.value) textareaRef.value.style.height = 'auto'
 
-  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') {
-          message.error(result.errorMessage || '生成出错')
-        }
-      },
-      onError: (error) => {
-        console.error('生成失败:', error)
-        message.error('生成失败，请重试')
-        if (!generatedContent.value) isGenerating.value = false
-      },
-      onClose: () => {
-        isGenerating.value = false
-        abortController.value = null
-      }
-    })
-    emit('send', { agentId: props.agent?.id, content: prompt, modelMode: modelMode.value })
-  } catch (error) {
-    if (error.name !== 'AbortError') {
-      message.error('生成失败，请重试')
-    }
-    isGenerating.value = false
-  }
+  await executeStreamRequest(prompt)
+  emit('send', { agentId: props.agent?.id, content: prompt, modelMode: modelMode.value })
 }
 
 const handleKeyDown = (e) => {
@@ -281,25 +266,17 @@ const handleKeyDown = (e) => {
 
 const handleCopy = async (content) => {
   const success = await copyToClipboard(content)
-  if (success) {
-    message.success('已复制')
-  } else {
-    message.error('复制失败')
-  }
+  success ? message.success('已复制') : message.error('复制失败')
 }
 
-const handleRegenerate = async () => {
-  if (!currentInput.value || isGenerating.value) return
-  generatedContent.value = ''
-  isGenerating.value = true
-  usedProMode.value = modelMode.value === 'pro'
-
+// 执行流式请求
+const executeStreamRequest = async (prompt) => {
   abortController.value = new AbortController()
 
   try {
     await sendChatStream({
       agentId: props.agent?.id,
-      content: currentInput.value,
+      content: prompt,
       modelMode: modelMode.value,
       ctrl: abortController.value,
       onMessage: (result) => {
@@ -325,6 +302,14 @@ const handleRegenerate = async () => {
   }
 }
 
+const handleRegenerate = async () => {
+  if (!currentInput.value || isGenerating.value) return
+  generatedContent.value = ''
+  isGenerating.value = true
+  usedProMode.value = modelMode.value === 'pro'
+  await executeStreamRequest(currentInput.value)
+}
+
 const resetTask = () => {
   generatedContent.value = ''
   currentInput.value = ''
@@ -336,6 +321,15 @@ const resetTask = () => {
   nextTick(() => textareaRef.value?.focus())
 }
 
+// History Methods
+const openHistory = () => {
+  historyVisible.value = true
+}
+
+const closeHistory = () => {
+  historyVisible.value = false
+}
+
 const scrollToBottom = () => {
   nextTick(() => {
     if (resultBodyRef.value) {
@@ -886,4 +880,30 @@ watch(() => props.visible, (val) => {
 .drawer-fade-leave-to {
   opacity: 0;
 }
+
+// Header Actions
+.header-actions {
+  display: flex;
+  align-items: center;
+  gap: 8px;
+}
+
+.history-btn {
+  width: 36px;
+  height: 36px;
+  border-radius: 10px;
+  border: none;
+  background: transparent;
+  color: @text-light;
+  cursor: pointer;
+  display: flex;
+  align-items: center;
+  justify-content: center;
+  transition: all 0.2s;
+
+  &:hover {
+    background: #f1f5f9;
+    color: @primary;
+  }
+}
 </style>
diff --git a/frontend/app/web-gold/src/components/agents/HistoryPanel.vue b/frontend/app/web-gold/src/components/agents/HistoryPanel.vue
new file mode 100644
index 0000000000..6d46d7545e
--- /dev/null
+++ b/frontend/app/web-gold/src/components/agents/HistoryPanel.vue
@@ -0,0 +1,595 @@
+<template>
+  <transition name="history-slide">
+    <div v-if="visible" class="history-panel">
+      <!-- Header -->
+      <header class="panel-header">
+        <div class="header-left">
+          <button v-if="selectedConversation" class="back-btn" @click="backToList">
+            <LeftOutlined />
+          </button>
+          <h3 class="header-title">{{ selectedConversation ? '对话详情' : '历史记录' }}</h3>
+        </div>
+        <button class="close-btn" @click="handleClose">
+          <CloseOutlined />
+        </button>
+      </header>
+
+      <!-- Content -->
+      <div class="panel-content">
+        <!-- Conversation List -->
+        <div v-if="!selectedConversation" class="conversation-view">
+          <a-spin :spinning="loading">
+            <!-- Empty State -->
+            <div v-if="groupedConversations.length === 0 && !loading" class="empty-state">
+              <div class="empty-visual">
+                <div class="visual-ring"></div>
+                <HistoryOutlined class="empty-icon" />
+              </div>
+              <p class="empty-text">暂无历史记录</p>
+              <p class="empty-hint">开始对话后，记录将保存在这里</p>
+            </div>
+
+            <!-- Grouped List -->
+            <div v-else class="conversation-groups">
+              <div
+                v-for="group in groupedConversations"
+                :key="group.label"
+                class="conversation-group"
+              >
+                <div class="group-header">
+                  <span class="group-label">{{ group.label }}</span>
+                  <span class="group-count">{{ group.items.length }}</span>
+                </div>
+                <div class="group-list">
+                  <button
+                    v-for="item in group.items"
+                    :key="item.id"
+                    class="conversation-card"
+                    @click="selectConversation(item)"
+                  >
+                    <div class="card-main">
+                      <h4 class="card-title">{{ item.name || '未命名会话' }}</h4>
+                      <p class="card-preview">{{ item.preview || '暂无预览' }}</p>
+                    </div>
+                    <div class="card-meta">
+                      <span class="meta-time">
+                        <ClockCircleOutlined />
+                        {{ formatTime(item.updatedAt || item.createdAt) }}
+                      </span>
+                      <RightOutlined class="meta-arrow" />
+                    </div>
+                  </button>
+                </div>
+              </div>
+            </div>
+          </a-spin>
+        </div>
+
+        <!-- Message Detail -->
+        <div v-else class="message-view">
+          <a-spin :spinning="messageLoading">
+            <div v-if="messageList.length === 0 && !messageLoading" class="empty-state">
+              <CommentOutlined class="empty-icon" />
+              <p>暂无消息</p>
+            </div>
+            <div v-else class="message-list">
+              <div v-for="(msg, index) in messageList" :key="msg.id" class="message-item">
+                <div class="message-bubble message-bubble--user">
+                  <div class="bubble-header">
+                    <UserOutlined class="bubble-avatar" />
+                    <span class="bubble-label">你的问题</span>
+                    <span class="bubble-time">{{ formatTime(msg.createdAt) }}</span>
+                  </div>
+                  <p class="bubble-content">{{ msg.query }}</p>
+                </div>
+                <div class="message-bubble message-bubble--ai">
+                  <div class="bubble-header">
+                    <RobotOutlined class="bubble-avatar" />
+                    <span class="bubble-label">AI 回答</span>
+                    <button class="bubble-copy" @click="copyContent(msg.answer)">
+                      <CopyOutlined />
+                    </button>
+                  </div>
+                  <p class="bubble-content">{{ msg.answer }}</p>
+                </div>
+              </div>
+            </div>
+          </a-spin>
+        </div>
+      </div>
+    </div>
+  </transition>
+</template>
+
+<script setup>
+import { ref, computed, watch } from 'vue'
+import {
+  CloseOutlined,
+  LeftOutlined,
+  RightOutlined,
+  HistoryOutlined,
+  ClockCircleOutlined,
+  CopyOutlined,
+  UserOutlined,
+  RobotOutlined,
+  CommentOutlined
+} from '@ant-design/icons-vue'
+import { message } from 'ant-design-vue'
+import dayjs from 'dayjs'
+import { getConversations, getMessages } from '@/api/agent'
+import { copyToClipboard } from '@/utils/clipboard'
+
+const props = defineProps({
+  visible: { type: Boolean, default: false },
+  agentId: { type: [String, Number], default: null }
+})
+
+const emit = defineEmits(['close'])
+
+// State
+const loading = ref(false)
+const conversationList = ref([])
+const selectedConversation = ref(null)
+const messageList = ref([])
+const messageLoading = ref(false)
+
+// 按日期分组
+const groupedConversations = computed(() => {
+  const today = dayjs().startOf('day')
+  const yesterday = dayjs().subtract(1, 'day').startOf('day')
+  const week = dayjs().subtract(7, 'day').startOf('day')
+
+  const groups = {
+    today: { label: '今天', items: [] },
+    yesterday: { label: '昨天', items: [] },
+    week: { label: '近7天', items: [] },
+    older: { label: '更早', items: [] }
+  }
+
+  conversationList.value.forEach(item => {
+    const date = dayjs((item.updatedAt || item.createdAt) * 1000)
+    if (date.isAfter(today)) {
+      groups.today.items.push(item)
+    } else if (date.isAfter(yesterday)) {
+      groups.yesterday.items.push(item)
+    } else if (date.isAfter(week)) {
+      groups.week.items.push(item)
+    } else {
+      groups.older.items.push(item)
+    }
+  })
+
+  return Object.values(groups).filter(g => g.items.length > 0)
+})
+
+// Methods
+const loadConversations = async () => {
+  if (!props.agentId) return
+  loading.value = true
+  try {
+    const res = await getConversations({ agentId: props.agentId, limit: 50 })
+    if (res.code === 0) {
+      conversationList.value = res.data?.data || []
+    }
+  } catch (e) {
+    console.error('加载会话列表失败:', e)
+  } finally {
+    loading.value = false
+  }
+}
+
+const selectConversation = async (conversation) => {
+  selectedConversation.value = conversation
+  messageLoading.value = true
+  messageList.value = []
+  try {
+    const res = await getMessages({
+      agentId: props.agentId,
+      conversationId: conversation.id,
+      limit: 50
+    })
+    if (res.code === 0) {
+      messageList.value = (res.data?.data || []).reverse()
+    }
+  } catch (e) {
+    console.error('加载消息详情失败:', e)
+  } finally {
+    messageLoading.value = false
+  }
+}
+
+const backToList = () => {
+  selectedConversation.value = null
+  messageList.value = []
+}
+
+const handleClose = () => {
+  emit('close')
+  backToList()
+}
+
+const copyContent = async (content) => {
+  const success = await copyToClipboard(content)
+  success ? message.success('已复制') : message.error('复制失败')
+}
+
+const formatTime = (timestamp) => {
+  if (!timestamp) return ''
+  const date = dayjs(timestamp * 1000)
+  const now = dayjs()
+
+  if (date.isSame(now, 'day')) {
+    return date.format('HH:mm')
+  } else if (date.isSame(now.subtract(1, 'day'), 'day')) {
+    return '昨天 ' + date.format('HH:mm')
+  } else if (date.isAfter(now.subtract(7, 'day'))) {
+    return date.format('dddd HH:mm')
+  } else {
+    return date.format('MM-DD HH:mm')
+  }
+}
+
+// Watch
+watch(() => props.visible, (val) => {
+  if (val) {
+    backToList()
+    loadConversations()
+  }
+})
+</script>
+
+<style scoped lang="less">
+@primary: #6366f1;
+@primary-light: rgba(99, 102, 241, 0.1);
+@surface: #ffffff;
+@bg: #f8fafc;
+@text: #1e293b;
+@text-light: #64748b;
+@text-muted: #94a3b8;
+@border: #e2e8f0;
+@radius: 12px;
+
+.history-panel {
+  position: absolute;
+  inset: 0;
+  background: @bg;
+  z-index: 20;
+  display: flex;
+  flex-direction: column;
+}
+
+// Header
+.panel-header {
+  display: flex;
+  align-items: center;
+  justify-content: space-between;
+  padding: 16px 20px;
+  background: rgba(255, 255, 255, 0.95);
+  backdrop-filter: blur(12px);
+  border-bottom: 1px solid @border;
+}
+
+.header-left {
+  display: flex;
+  align-items: center;
+  gap: 12px;
+}
+
+.back-btn {
+  width: 32px;
+  height: 32px;
+  border-radius: 8px;
+  border: none;
+  background: transparent;
+  color: @text-light;
+  cursor: pointer;
+  display: flex;
+  align-items: center;
+  justify-content: center;
+  transition: all 0.2s;
+
+  &:hover {
+    background: #f1f5f9;
+    color: @text;
+  }
+}
+
+.header-title {
+  font-size: 15px;
+  font-weight: 600;
+  color: @text;
+  margin: 0;
+}
+
+.close-btn {
+  width: 32px;
+  height: 32px;
+  border-radius: 8px;
+  border: none;
+  background: transparent;
+  color: @text-light;
+  cursor: pointer;
+  display: flex;
+  align-items: center;
+  justify-content: center;
+  transition: all 0.2s;
+
+  &:hover {
+    background: #fee2e2;
+    color: #ef4444;
+  }
+}
+
+// Content
+.panel-content {
+  flex: 1;
+  overflow-y: auto;
+  padding: 16px;
+}
+
+// Empty State
+.empty-state {
+  display: flex;
+  flex-direction: column;
+  align-items: center;
+  justify-content: center;
+  padding: 80px 20px;
+  text-align: center;
+}
+
+.empty-visual {
+  position: relative;
+  width: 80px;
+  height: 80px;
+  margin-bottom: 24px;
+}
+
+.visual-ring {
+  position: absolute;
+  inset: 0;
+  border-radius: 50%;
+  border: 2px dashed @border;
+  animation: ringRotate 20s linear infinite;
+}
+
+@keyframes ringRotate {
+  to { transform: rotate(360deg); }
+}
+
+.empty-icon {
+  position: absolute;
+  top: 50%;
+  left: 50%;
+  transform: translate(-50%, -50%);
+  font-size: 32px;
+  color: @text-muted;
+}
+
+.empty-text {
+  font-size: 15px;
+  font-weight: 500;
+  color: @text;
+  margin: 0 0 6px;
+}
+
+.empty-hint {
+  font-size: 13px;
+  color: @text-muted;
+  margin: 0;
+}
+
+// Conversation Groups
+.conversation-groups {
+  display: flex;
+  flex-direction: column;
+  gap: 20px;
+}
+
+.conversation-group {
+  // Group styling
+}
+
+.group-header {
+  display: flex;
+  align-items: center;
+  gap: 8px;
+  margin-bottom: 10px;
+  padding: 0 4px;
+}
+
+.group-label {
+  font-size: 12px;
+  font-weight: 600;
+  color: @text-light;
+  text-transform: uppercase;
+  letter-spacing: 0.5px;
+}
+
+.group-count {
+  font-size: 11px;
+  font-weight: 500;
+  color: @text-muted;
+  background: #f1f5f9;
+  padding: 2px 8px;
+  border-radius: 10px;
+}
+
+.group-list {
+  display: flex;
+  flex-direction: column;
+  gap: 8px;
+}
+
+// Conversation Card
+.conversation-card {
+  width: 100%;
+  display: flex;
+  align-items: center;
+  justify-content: space-between;
+  padding: 14px 16px;
+  background: @surface;
+  border: 1px solid @border;
+  border-radius: @radius;
+  cursor: pointer;
+  transition: all 0.2s;
+  text-align: left;
+
+  &:hover {
+    border-color: @primary;
+    box-shadow: 0 4px 12px rgba(99, 102, 241, 0.1);
+    transform: translateY(-1px);
+
+    .meta-arrow {
+      color: @primary;
+      transform: translateX(2px);
+    }
+  }
+}
+
+.card-main {
+  flex: 1;
+  min-width: 0;
+}
+
+.card-title {
+  font-size: 14px;
+  font-weight: 600;
+  color: @text;
+  margin: 0 0 4px;
+  overflow: hidden;
+  text-overflow: ellipsis;
+  white-space: nowrap;
+}
+
+.card-preview {
+  font-size: 12px;
+  color: @text-muted;
+  margin: 0;
+  overflow: hidden;
+  text-overflow: ellipsis;
+  white-space: nowrap;
+}
+
+.card-meta {
+  display: flex;
+  flex-direction: column;
+  align-items: flex-end;
+  gap: 4px;
+  flex-shrink: 0;
+  margin-left: 12px;
+}
+
+.meta-time {
+  display: flex;
+  align-items: center;
+  gap: 4px;
+  font-size: 11px;
+  color: @text-muted;
+}
+
+.meta-arrow {
+  font-size: 10px;
+  color: @text-muted;
+  transition: all 0.2s;
+}
+
+// Message View
+.message-view {
+  // Message view container
+}
+
+.message-list {
+  display: flex;
+  flex-direction: column;
+  gap: 20px;
+}
+
+.message-item {
+  display: flex;
+  flex-direction: column;
+  gap: 12px;
+}
+
+.message-bubble {
+  border-radius: @radius;
+  overflow: hidden;
+
+  &--user {
+    background: linear-gradient(135deg, #f8fafc, #f1f5f9);
+    border: 1px solid @border;
+  }
+
+  &--ai {
+    background: linear-gradient(135deg, @primary-light, rgba(139, 92, 246, 0.08));
+    border: 1px solid rgba(99, 102, 241, 0.2);
+  }
+}
+
+.bubble-header {
+  display: flex;
+  align-items: center;
+  gap: 8px;
+  padding: 10px 14px;
+  border-bottom: 1px solid rgba(0, 0, 0, 0.05);
+}
+
+.bubble-avatar {
+  font-size: 14px;
+  color: @text-light;
+}
+
+.bubble-label {
+  font-size: 11px;
+  font-weight: 600;
+  color: @text-light;
+  text-transform: uppercase;
+  letter-spacing: 0.3px;
+}
+
+.bubble-time {
+  font-size: 10px;
+  color: @text-muted;
+  margin-left: auto;
+}
+
+.bubble-copy {
+  margin-left: auto;
+  width: 24px;
+  height: 24px;
+  border: none;
+  background: transparent;
+  color: @text-muted;
+  border-radius: 6px;
+  cursor: pointer;
+  display: flex;
+  align-items: center;
+  justify-content: center;
+  transition: all 0.2s;
+
+  &:hover {
+    background: rgba(99, 102, 241, 0.1);
+    color: @primary;
+  }
+}
+
+.bubble-content {
+  margin: 0;
+  padding: 12px 14px;
+  font-size: 13px;
+  line-height: 1.7;
+  color: @text;
+  white-space: pre-wrap;
+  word-break: break-word;
+}
+
+// Transition
+.history-slide-enter-active,
+.history-slide-leave-active {
+  transition: transform 0.3s cubic-bezier(0.32, 0.72, 0, 1);
+}
+
+.history-slide-enter-from,
+.history-slide-leave-to {
+  transform: translateX(100%);
+}
+</style>
diff --git a/frontend/app/web-gold/src/views/agents/Agents.vue b/frontend/app/web-gold/src/views/agents/Agents.vue
index 185dfbb8d4..b81ad421f3 100644
--- a/frontend/app/web-gold/src/views/agents/Agents.vue
+++ b/frontend/app/web-gold/src/views/agents/Agents.vue
@@ -19,7 +19,6 @@
                 type="text"
                 placeholder="搜索智能体..."
                 class="search-input"
-                @keydown.enter="handleSearch"
               />
               <transition name="fade">
                 <button v-if="searchKeyword" class="search-clear" @click="clearSearch">
@@ -34,7 +33,7 @@
             <div class="category-scroll" ref="categoryScrollRef">
               <div class="category-track">
                 <button
-                  v-for="category in visibleCategories"
+                  v-for="category in categories"
                   :key="category.id"
                   :data-category-id="category.id"
                   class="category-chip"
@@ -46,10 +45,54 @@
                 </button>
               </div>
             </div>
+
+            <!-- 展开按钮 -->
+            <button
+              ref="expandTriggerRef"
+              class="expand-trigger"
+              :class="{ 'expand-trigger--active': showCategoryPanel }"
+              @click="toggleCategoryPanel"
+            >
+              <span class="expand-icon">
+                <AppstoreOutlined />
+              </span>
+            </button>
           </div>
         </div>
       </header>
 
+      <!-- 分类展开面板 - Teleport 到 body -->
+      <Teleport to="body">
+        <!-- 遮罩层 -->
+        <transition name="mask">
+          <div v-if="showCategoryPanel" class="category-mask" @click="showCategoryPanel = false"></div>
+        </transition>
+
+        <!-- 面板 -->
+        <transition name="panel">
+          <div v-if="showCategoryPanel" class="category-panel" :style="panelStyle">
+            <div class="panel-header">
+              <span class="panel-title">快速选择</span>
+              <button class="panel-close" @click="showCategoryPanel = false">
+                <CloseOutlined />
+              </button>
+            </div>
+            <div class="panel-grid">
+              <button
+                v-for="category in categories"
+                :key="category.id"
+                class="panel-chip"
+                :class="{ 'panel-chip--active': activeCategory === category.id }"
+                @click="handleCategoryFromPanel(category.id)"
+              >
+                <span class="panel-chip-name">{{ category.name }}</span>
+                <span class="panel-chip-count">{{ category.count }}</span>
+              </button>
+            </div>
+          </div>
+        </transition>
+      </Teleport>
+
       <!-- 主内容区域 -->
       <main class="agents-main">
         <a-spin :spinning="loading" class="loading-spinner">
@@ -128,7 +171,8 @@ import {
   RobotOutlined,
   CloseOutlined,
   ArrowRightOutlined,
-  MessageOutlined
+  MessageOutlined,
+  AppstoreOutlined
 } from '@ant-design/icons-vue'
 import { message } from 'ant-design-vue'
 import FullWidthLayout from '@/layouts/components/FullWidthLayout.vue'
@@ -142,6 +186,14 @@ const searchKeyword = ref('')
 const chatDrawerVisible = ref(false)
 const currentAgent = ref(null)
 const categoryScrollRef = ref(null)
+const expandTriggerRef = ref(null)
+const showCategoryPanel = ref(false)
+const panelTop = ref(0)
+
+// 面板样式
+const panelStyle = computed(() => ({
+  top: `${panelTop.value}px`
+}))
 
 // 智能体列表数据
 const agentList = ref([])
@@ -166,9 +218,6 @@ const categories = computed(() => {
   return cats
 })
 
-// 可见分类（用于展示）
-const visibleCategories = computed(() => categories.value)
-
 // 过滤后的列表
 const filteredAgentList = computed(() => {
   let list = agentList.value
@@ -242,8 +291,18 @@ const handleCategoryChange = (categoryId) => {
   scrollCategoryIntoView(categoryId)
 }
 
-const handleSearch = () => {
-  // 搜索逻辑通过 computed 自动处理
+const toggleCategoryPanel = () => {
+  if (!showCategoryPanel.value && expandTriggerRef.value) {
+    const rect = expandTriggerRef.value.getBoundingClientRect()
+    panelTop.value = rect.bottom + 8
+  }
+  showCategoryPanel.value = !showCategoryPanel.value
+}
+
+const handleCategoryFromPanel = (categoryId) => {
+  activeCategory.value = categoryId
+  scrollCategoryIntoView(categoryId)
+  showCategoryPanel.value = false
 }
 
 const clearSearch = () => {
@@ -334,6 +393,7 @@ onMounted(() => {
   padding: 48px 0 32px;
   background: var(--surface-primary);
   border-bottom: 1px solid var(--border-light);
+  z-index: 10;
 }
 
 .header-decoration {
@@ -456,6 +516,9 @@ onMounted(() => {
 .category-filter {
   display: flex;
   justify-content: center;
+  align-items: center;
+  gap: 8px;
+  position: relative;
 }
 
 .category-scroll {
@@ -832,4 +895,206 @@ onMounted(() => {
 .fade-leave-to {
   opacity: 0;
 }
+
+// ============================================
+// 展开按钮
+// ============================================
+.expand-trigger {
+  flex-shrink: 0;
+  width: 34px;
+  height: 34px;
+  border: 1px solid var(--border-subtle);
+  border-radius: 10px;
+  background: var(--surface-elevated);
+  cursor: pointer;
+  display: flex;
+  align-items: center;
+  justify-content: center;
+  color: var(--text-tertiary);
+  transition: all var(--transition-fast);
+
+  &:hover {
+    border-color: var(--text-tertiary);
+    color: var(--text-secondary);
+    background: var(--surface-muted);
+  }
+
+  &--active {
+    background: var(--text-primary);
+    border-color: var(--text-primary);
+    color: white;
+  }
+}
+
+.expand-icon {
+  font-size: 14px;
+}
+</style>
+
+<!-- 全局样式 - 用于 Teleport 到 body 的元素 -->
+<style lang="less">
+.category-panel {
+  position: fixed;
+  left: 50%;
+  transform: translateX(-50%);
+  width: 320px;
+  max-width: calc(100vw - 48px);
+  background: #FFFFFF;
+  border-radius: 14px;
+  box-shadow: 0 12px 32px rgba(0,0,0,0.12), 0 4px 12px rgba(0,0,0,0.08);
+  border: 1px solid #F0F0F0;
+  z-index: 1001;
+  overflow: hidden;
+}
+
+.category-panel .panel-header {
+  display: flex;
+  align-items: center;
+  justify-content: space-between;
+  padding: 14px 16px;
+  border-bottom: 1px solid #F0F0F0;
+}
+
+.category-panel .panel-title {
+  font-size: 13px;
+  font-weight: 600;
+  color: #171717;
+}
+
+.category-panel .panel-close {
+  width: 24px;
+  height: 24px;
+  border: none;
+  background: transparent;
+  border-radius: 6px;
+  cursor: pointer;
+  display: flex;
+  align-items: center;
+  justify-content: center;
+  color: #A3A3A3;
+  font-size: 10px;
+  transition: all 0.15s cubic-bezier(0.4, 0, 0.2, 1);
+}
+
+.category-panel .panel-close:hover {
+  background: #F5F5F5;
+  color: #525252;
+}
+
+.category-panel .panel-grid {
+  display: grid;
+  grid-template-columns: repeat(2, 1fr);
+  gap: 8px;
+  padding: 12px;
+  max-height: 280px;
+  overflow-y: auto;
+}
+
+.category-panel .panel-grid::-webkit-scrollbar {
+  width: 4px;
+}
+
+.category-panel .panel-grid::-webkit-scrollbar-thumb {
+  background: #E5E5E5;
+  border-radius: 2px;
+}
+
+.category-panel .panel-chip {
+  display: flex;
+  align-items: center;
+  justify-content: space-between;
+  padding: 10px 12px;
+  border: 1px solid #F0F0F0;
+  border-radius: 10px;
+  background: #FFFFFF;
+  cursor: pointer;
+  transition: all 0.15s cubic-bezier(0.4, 0, 0.2, 1);
+}
+
+.category-panel .panel-chip:hover:not(.panel-chip--active) {
+  border-color: #E5E5E5;
+  background: #F5F5F5;
+}
+
+.category-panel .panel-chip--active {
+  background: #171717;
+  border-color: #171717;
+}
+
+.category-panel .panel-chip--active .panel-chip-name,
+.category-panel .panel-chip--active .panel-chip-count {
+  color: white;
+}
+
+.category-panel .panel-chip--active .panel-chip-count {
+  background: rgba(255,255,255,0.2);
+}
+
+.category-panel .panel-chip-name {
+  font-size: 13px;
+  font-weight: 500;
+  color: #171717;
+  white-space: nowrap;
+  overflow: hidden;
+  text-overflow: ellipsis;
+}
+
+.category-panel .panel-chip-count {
+  font-size: 11px;
+  font-weight: 600;
+  padding: 2px 6px;
+  border-radius: 6px;
+  background: #F5F5F5;
+  color: #525252;
+  flex-shrink: 0;
+  margin-left: 8px;
+}
+
+.category-mask {
+  position: fixed;
+  inset: 0;
+  z-index: 1000;
+  background: transparent;
+}
+
+// 面板动画 - 全局
+.panel-enter-active {
+  animation: panelIn 0.2s ease-out;
+}
+
+.panel-leave-active {
+  animation: panelOut 0.15s ease-in;
+}
+
+@keyframes panelIn {
+  from {
+    opacity: 0;
+    transform: translateX(-50%) translateY(-8px) scale(0.96);
+  }
+  to {
+    opacity: 1;
+    transform: translateX(-50%) translateY(0) scale(1);
+  }
+}
+
+@keyframes panelOut {
+  from {
+    opacity: 1;
+    transform: translateX(-50%) translateY(0) scale(1);
+  }
+  to {
+    opacity: 0;
+    transform: translateX(-50%) translateY(-8px) scale(0.96);
+  }
+}
+
+.mask-enter-active,
+.mask-leave-active {
+  transition: opacity 0.15s ease;
+}
+
+.mask-enter-from,
+.mask-leave-to {
+  opacity: 0;
+}
 </style>
diff --git a/frontend/app/web-gold/src/views/kling/IdentifyFace.vue b/frontend/app/web-gold/src/views/kling/IdentifyFace.vue
index a346f7eb4d..3860e5516d 100644
--- a/frontend/app/web-gold/src/views/kling/IdentifyFace.vue
+++ b/frontend/app/web-gold/src/views/kling/IdentifyFace.vue
@@ -292,7 +292,10 @@ const handleFileSelectWrapper = (e: Event) => {
 }
 
 onMounted(async () => {
-  await voiceStore.refresh()
+  await Promise.all([
+    voiceStore.refresh(),
+    userStore.fetchUserProfile()
+  ])
 })
 </script>
 
diff --git a/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/client/DifyClient.java b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/client/DifyClient.java
index 88a9097c77..1b11a6e54c 100644
--- a/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/client/DifyClient.java
+++ b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/client/DifyClient.java
@@ -2,6 +2,8 @@ package cn.iocoder.yudao.module.tik.dify.client;
 
 import cn.iocoder.yudao.module.tik.dify.config.DifyProperties;
 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.DifyMessageListRespVO;
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import jakarta.annotation.Resource;
@@ -38,9 +40,10 @@ public class DifyClient {
      * @param content        用户输入
      * @param systemPrompt   系统提示词
      * @param conversationId 会话ID（可选）
+     * @param userId         用户标识（固定）
      * @return 流式响应
      */
-    public Flux<DifyChatRespVO> chatStream(String apiKey, String content, String systemPrompt, String conversationId) {
+    public Flux<DifyChatRespVO> chatStream(String apiKey, String content, String systemPrompt, String conversationId, String userId) {
         String apiUrl = difyProperties.getApiUrl() + "/v1/chat-messages";
 
         // 构建请求体 - 按照 Dify API 格式
@@ -52,7 +55,7 @@ public class DifyClient {
         requestBody.put("query", content);
         requestBody.put("response_mode", "streaming");
         requestBody.put("conversation_id", conversationId != null ? conversationId : "");
-        requestBody.put("user", "user-" + System.currentTimeMillis());
+        requestBody.put("user", userId);
 
         AtomicReference<String> responseConversationId = new AtomicReference<>(conversationId);
         StringBuilder fullContent = new StringBuilder();
@@ -91,9 +94,10 @@ public class DifyClient {
      * @param inputs         自定义输入参数
      * @param content        用户输入
      * @param conversationId 会话ID（可选）
+     * @param userId         用户标识（固定）
      * @return 流式响应
      */
-    public Flux<DifyChatRespVO> chatStreamWithInputs(String apiKey, Map<String, Object> inputs, String content, String conversationId) {
+    public Flux<DifyChatRespVO> chatStreamWithInputs(String apiKey, Map<String, Object> inputs, String content, String conversationId, String userId) {
         String apiUrl = difyProperties.getApiUrl() + "/v1/chat-messages";
 
         Map<String, Object> requestBody = new HashMap<>();
@@ -101,7 +105,7 @@ public class DifyClient {
         requestBody.put("query", content);
         requestBody.put("response_mode", "streaming");
         requestBody.put("conversation_id", conversationId != null ? conversationId : "");
-        requestBody.put("user", "user-" + System.currentTimeMillis());
+        requestBody.put("user", userId);
 
         // 调试日志：打印完整请求体
         try {
@@ -195,4 +199,77 @@ public class DifyClient {
         }
     }
 
+    /**
+     * 获取会话列表
+     *
+     * @param apiKey Dify API Key
+     * @param user   用户标识
+     * @param lastId 上一页最后一条记录ID（用于分页）
+     * @param limit  返回条数
+     * @return 会话列表
+     */
+    public DifyConversationListRespVO getConversations(String apiKey, String user, String lastId, Integer limit) {
+        StringBuilder params = new StringBuilder("?user=").append(user);
+        if (lastId != null && !lastId.isEmpty()) {
+            params.append("&last_id=").append(lastId);
+        }
+        if (limit != null) {
+            params.append("&limit=").append(limit);
+        }
+
+        String url = difyProperties.getApiUrl() + "/v1/conversations" + params;
+        try {
+            String response = executeGetRequest(url, apiKey);
+            log.info("[getConversations] 获取会话列表成功，user: {}", user);
+            return objectMapper.readValue(response, DifyConversationListRespVO.class);
+        } catch (Exception e) {
+            log.error("[getConversations] 获取会话列表失败，user: {}", user, e);
+            throw new RuntimeException("获取会话列表失败: " + e.getMessage());
+        }
+    }
+
+    /**
+     * 获取会话历史消息
+     *
+     * @param apiKey         Dify API Key
+     * @param conversationId 会话ID
+     * @param user           用户标识
+     * @param firstId        当前页第一条记录ID（用于分页）
+     * @param limit          返回条数
+     * @return 消息列表
+     */
+    public DifyMessageListRespVO getMessages(String apiKey, String conversationId, String user, String firstId, Integer limit) {
+        StringBuilder params = new StringBuilder("?conversation_id=").append(conversationId).append("&user=").append(user);
+        if (firstId != null && !firstId.isEmpty()) {
+            params.append("&first_id=").append(firstId);
+        }
+        if (limit != null) {
+            params.append("&limit=").append(limit);
+        }
+
+        String url = difyProperties.getApiUrl() + "/v1/messages" + params;
+        try {
+            String response = executeGetRequest(url, apiKey);
+            log.info("[getMessages] 获取会话消息成功，conversationId: {}, user: {}", conversationId, user);
+            return objectMapper.readValue(response, DifyMessageListRespVO.class);
+        } catch (Exception e) {
+            log.error("[getMessages] 获取会话消息失败，conversationId: {}, user: {}", conversationId, user, e);
+            throw new RuntimeException("获取会话消息失败: " + e.getMessage());
+        }
+    }
+
+    /**
+     * 执行 GET 请求
+     */
+    private String executeGetRequest(String url, String apiKey) {
+        return WebClient.builder()
+                .baseUrl(url)
+                .defaultHeader("Authorization", "Bearer " + apiKey)
+                .build()
+                .get()
+                .retrieve()
+                .bodyToMono(String.class)
+                .block();
+    }
+
 }
diff --git a/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/controller/AppDifyController.java b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/controller/AppDifyController.java
index d8dd446c46..17253603ec 100644
--- a/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/controller/AppDifyController.java
+++ b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/controller/AppDifyController.java
@@ -5,15 +5,20 @@ import cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils;
 import cn.iocoder.yudao.module.tik.dify.service.DifyService;
 import cn.iocoder.yudao.module.tik.dify.vo.DifyChatReqVO;
 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.DifyMessageListRespVO;
 import cn.iocoder.yudao.module.tik.dify.vo.ForecastRewriteReqVO;
 import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.annotation.Resource;
 import jakarta.validation.Valid;
 import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 import reactor.core.publisher.Flux;
 
@@ -27,27 +32,54 @@ import reactor.core.publisher.Flux;
 @RequestMapping("/api/tik/dify")
 public class AppDifyController {
 
+    private static final String DEFAULT_USER_ID = "1";
+
     @Resource
     private DifyService difyService;
 
     @PostMapping(value = "/chat/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
     @Operation(summary = "流式聊天")
     public Flux<CommonResult<DifyChatRespVO>> chatStream(@Valid @RequestBody DifyChatReqVO reqVO) {
-        Long loginUserId = SecurityFrameworkUtils.getLoginUserId();
-        String userId = loginUserId != null ? loginUserId.toString() : "1"; // 默认用户ID
-
-        return difyService.chatStream(reqVO, userId)
+        return difyService.chatStream(reqVO, getCurrentUserId())
                 .map(CommonResult::success);
     }
 
     @PostMapping(value = "/forecast/rewrite", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
     @Operation(summary = "Forecast 文案改写（流式）")
     public Flux<CommonResult<DifyChatRespVO>> rewriteStream(@Valid @RequestBody ForecastRewriteReqVO reqVO) {
-        Long loginUserId = SecurityFrameworkUtils.getLoginUserId();
-        String userId = loginUserId != null ? loginUserId.toString() : "1"; // 默认用户ID
-
-        return difyService.rewriteStream(reqVO, userId)
+        return difyService.rewriteStream(reqVO, getCurrentUserId())
                 .map(CommonResult::success);
     }
 
+    @GetMapping("/conversations")
+    @Operation(summary = "获取会话列表")
+    @Parameter(name = "agentId", description = "智能体ID", required = true)
+    @Parameter(name = "lastId", description = "上一页最后一条记录ID")
+    @Parameter(name = "limit", description = "返回条数，默认20")
+    public CommonResult<DifyConversationListRespVO> getConversations(
+            @RequestParam("agentId") Long agentId,
+            @RequestParam(value = "lastId", required = false) String lastId,
+            @RequestParam(value = "limit", required = false) Integer limit) {
+        return CommonResult.success(difyService.getConversations(agentId, getCurrentUserId(), lastId, limit));
+    }
+
+    @GetMapping("/messages")
+    @Operation(summary = "获取会话历史消息")
+    @Parameter(name = "agentId", description = "智能体ID", required = true)
+    @Parameter(name = "conversationId", description = "会话ID", required = true)
+    @Parameter(name = "firstId", description = "当前页第一条记录ID")
+    @Parameter(name = "limit", description = "返回条数，默认20")
+    public CommonResult<DifyMessageListRespVO> getMessages(
+            @RequestParam("agentId") Long agentId,
+            @RequestParam("conversationId") String conversationId,
+            @RequestParam(value = "firstId", required = false) String firstId,
+            @RequestParam(value = "limit", required = false) Integer limit) {
+        return CommonResult.success(difyService.getMessages(agentId, conversationId, getCurrentUserId(), firstId, limit));
+    }
+
+    private String getCurrentUserId() {
+        Long loginUserId = SecurityFrameworkUtils.getLoginUserId();
+        return loginUserId != null ? loginUserId.toString() : DEFAULT_USER_ID;
+    }
+
 }
diff --git a/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/service/DifyService.java b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/service/DifyService.java
index 20f9a322a5..b7d6212ab8 100644
--- a/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/service/DifyService.java
+++ b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/service/DifyService.java
@@ -2,6 +2,8 @@ package cn.iocoder.yudao.module.tik.dify.service;
 
 import cn.iocoder.yudao.module.tik.dify.vo.DifyChatReqVO;
 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.DifyMessageListRespVO;
 import cn.iocoder.yudao.module.tik.dify.vo.ForecastRewriteReqVO;
 import reactor.core.publisher.Flux;
 
@@ -30,4 +32,27 @@ public interface DifyService {
      */
     Flux<DifyChatRespVO> rewriteStream(ForecastRewriteReqVO reqVO, String userId);
 
+    /**
+     * 获取会话列表
+     *
+     * @param agentId 智能体ID
+     * @param userId  用户ID
+     * @param lastId  上一页最后一条记录ID
+     * @param limit   返回条数
+     * @return 会话列表
+     */
+    DifyConversationListRespVO getConversations(Long agentId, String userId, String lastId, Integer limit);
+
+    /**
+     * 获取会话历史消息
+     *
+     * @param agentId        智能体ID
+     * @param conversationId 会话ID
+     * @param userId         用户ID
+     * @param firstId        当前页第一条记录ID
+     * @param limit          返回条数
+     * @return 消息列表
+     */
+    DifyMessageListRespVO getMessages(Long agentId, String conversationId, String userId, String firstId, Integer limit);
+
 }
diff --git a/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/service/DifyServiceImpl.java b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/service/DifyServiceImpl.java
index 7326b5014d..8b76085e3b 100644
--- a/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/service/DifyServiceImpl.java
+++ b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/service/DifyServiceImpl.java
@@ -3,6 +3,8 @@ package cn.iocoder.yudao.module.tik.dify.service;
 import cn.iocoder.yudao.module.tik.dify.client.DifyClient;
 import cn.iocoder.yudao.module.tik.dify.vo.DifyChatReqVO;
 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.DifyMessageListRespVO;
 import cn.iocoder.yudao.module.tik.dify.vo.ForecastRewriteReqVO;
 import cn.iocoder.yudao.module.tik.enums.AiModelTypeEnum;
 import cn.iocoder.yudao.module.tik.enums.AiPlatformEnum;
@@ -47,6 +49,8 @@ public class DifyServiceImpl implements DifyService {
         AtomicLong pendingRecordId = new AtomicLong();
         // 用于存储会话ID
         AtomicReference<String> conversationIdRef = new AtomicReference<>(reqVO.getConversationId());
+        // Dify 用户标识（固定格式）
+        String difyUserId = "user-" + userId;
 
         return Mono.fromCallable(() -> {
                     // 1. 获取智能体配置
@@ -84,7 +88,8 @@ public class DifyServiceImpl implements DifyService {
                                     context.apiKey(),
                                     reqVO.getContent(),
                                     context.systemPrompt(),
-                                    reqVO.getConversationId()
+                                    reqVO.getConversationId(),
+                                    difyUserId
                             )
                             .doOnNext(resp -> {
                                 if (resp.getConversationId() != null) {
@@ -142,6 +147,8 @@ public class DifyServiceImpl implements DifyService {
         AtomicLong pendingRecordId = new AtomicLong();
         // 用于存储会话ID
         AtomicReference<String> conversationIdRef = new AtomicReference<>("");
+        // Dify 用户标识（固定格式）
+        String difyUserId = "user-" + userId;
 
         return Mono.fromCallable(() -> {
                     // 1. 获取智能体配置（通过 agentId 获取 systemPrompt）
@@ -199,7 +206,8 @@ public class DifyServiceImpl implements DifyService {
                                     context.apiKey(),
                                     context.inputs(),
                                     reqVO.getUserText(),
-                                    null
+                                    null,
+                                    difyUserId
                             )
                             .doOnNext(resp -> {
                                 if (resp.getConversationId() != null) {
@@ -260,4 +268,42 @@ public class DifyServiceImpl implements DifyService {
      */
     private record ForecastRewriteContext(Map<String, Object> inputs, String apiKey, Integer consumePoints) {}
 
+    @Override
+    public DifyConversationListRespVO getConversations(Long agentId, String userId, String lastId, Integer limit) {
+        // 获取智能体配置
+        AiAgentDO agent = aiAgentService.getAiAgent(agentId);
+        if (agent == null) {
+            throw new RuntimeException("智能体不存在");
+        }
+
+        // 获取积分配置（使用标准模式的 API Key）
+        AiModelConfigDO config = pointsService.getConfig(
+                AiPlatformEnum.DIFY.getPlatform(),
+                AiModelTypeEnum.DIFY_WRITING_STANDARD.getModelCode());
+
+        // Dify 用户标识
+        String difyUserId = "user-" + userId;
+
+        return difyClient.getConversations(config.getApiKey(), difyUserId, lastId, limit);
+    }
+
+    @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("智能体不存在");
+        }
+
+        // 获取积分配置（使用标准模式的 API Key）
+        AiModelConfigDO config = pointsService.getConfig(
+                AiPlatformEnum.DIFY.getPlatform(),
+                AiModelTypeEnum.DIFY_WRITING_STANDARD.getModelCode());
+
+        // Dify 用户标识
+        String difyUserId = "user-" + userId;
+
+        return difyClient.getMessages(config.getApiKey(), conversationId, difyUserId, firstId, limit);
+    }
+
 }
diff --git a/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/vo/DifyConversationListRespVO.java b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/vo/DifyConversationListRespVO.java
new file mode 100644
index 0000000000..a8abab6c03
--- /dev/null
+++ b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/vo/DifyConversationListRespVO.java
@@ -0,0 +1,26 @@
+package cn.iocoder.yudao.module.tik.dify.vo;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * Dify 会话列表响应 VO
+ *
+ * @author 芋道源码
+ */
+@Schema(description = "Dify 会话列表响应")
+@Data
+public class DifyConversationListRespVO {
+
+    @Schema(description = "返回条数", requiredMode = Schema.RequiredMode.REQUIRED)
+    private Integer limit;
+
+    @Schema(description = "是否有更多数据", requiredMode = Schema.RequiredMode.REQUIRED)
+    private Boolean hasMore;
+
+    @Schema(description = "会话列表", requiredMode = Schema.RequiredMode.REQUIRED)
+    private List<DifyConversationRespVO> data;
+
+}
diff --git a/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/vo/DifyConversationRespVO.java b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/vo/DifyConversationRespVO.java
new file mode 100644
index 0000000000..c4fae07a18
--- /dev/null
+++ b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/vo/DifyConversationRespVO.java
@@ -0,0 +1,41 @@
+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;
+
+import java.util.Map;
+
+/**
+ * Dify 会话响应 VO
+ *
+ * @author 芋道源码
+ */
+@Schema(description = "Dify 会话响应")
+@Data
+public class DifyConversationRespVO {
+
+    @Schema(description = "会话ID", requiredMode = Schema.RequiredMode.REQUIRED)
+    private String id;
+
+    @Schema(description = "会话名称")
+    private String name;
+
+    @Schema(description = "输入参数")
+    private Map<String, Object> inputs;
+
+    @Schema(description = "会话状态")
+    private String status;
+
+    @Schema(description = "开场白")
+    private String introduction;
+
+    @Schema(description = "创建时间（时间戳）")
+    @JsonProperty("created_at")
+    private Long createdAt;
+
+    @Schema(description = "更新时间（时间戳）")
+    @JsonProperty("updated_at")
+    private Long updatedAt;
+
+}
diff --git a/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/vo/DifyMessageListRespVO.java b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/vo/DifyMessageListRespVO.java
new file mode 100644
index 0000000000..884e543056
--- /dev/null
+++ b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/vo/DifyMessageListRespVO.java
@@ -0,0 +1,26 @@
+package cn.iocoder.yudao.module.tik.dify.vo;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * Dify 消息列表响应 VO
+ *
+ * @author 芋道源码
+ */
+@Schema(description = "Dify 消息列表响应")
+@Data
+public class DifyMessageListRespVO {
+
+    @Schema(description = "返回条数", requiredMode = Schema.RequiredMode.REQUIRED)
+    private Integer limit;
+
+    @Schema(description = "是否有更多数据", requiredMode = Schema.RequiredMode.REQUIRED)
+    private Boolean hasMore;
+
+    @Schema(description = "消息列表", requiredMode = Schema.RequiredMode.REQUIRED)
+    private List<DifyMessageRespVO> data;
+
+}
diff --git a/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/vo/DifyMessageRespVO.java b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/vo/DifyMessageRespVO.java
new file mode 100644
index 0000000000..5f40e149e0
--- /dev/null
+++ b/yudao-module-tik/src/main/java/cn/iocoder/yudao/module/tik/dify/vo/DifyMessageRespVO.java
@@ -0,0 +1,67 @@
+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;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Dify 消息响应 VO
+ *
+ * @author 芋道源码
+ */
+@Schema(description = "Dify 消息响应")
+@Data
+public class DifyMessageRespVO {
+
+    @Schema(description = "消息ID", requiredMode = Schema.RequiredMode.REQUIRED)
+    private String id;
+
+    @Schema(description = "会话ID", requiredMode = Schema.RequiredMode.REQUIRED)
+    @JsonProperty("conversation_id")
+    private String conversationId;
+
+    @Schema(description = "输入参数")
+    private Map<String, Object> inputs;
+
+    @Schema(description = "用户问题", requiredMode = Schema.RequiredMode.REQUIRED)
+    private String query;
+
+    @Schema(description = "AI回答", requiredMode = Schema.RequiredMode.REQUIRED)
+    private String answer;
+
+    @Schema(description = "消息文件列表")
+    @JsonProperty("message_files")
+    private List<MessageFile> messageFiles;
+
+    @Schema(description = "用户反馈")
+    private Feedback feedback;
+
+    @Schema(description = "创建时间（时间戳）")
+    @JsonProperty("created_at")
+    private Long createdAt;
+
+    /**
+     * 消息文件
+     */
+    @Data
+    public static class MessageFile {
+        private String id;
+        private String type;
+        private String url;
+
+        @JsonProperty("belongs_to")
+        private String belongsTo;
+    }
+
+    /**
+     * 用户反馈
+     */
+    @Data
+    public static class Feedback {
+        private String rating;
+    }
+
+}