ChatWidget.tsx 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023
  1. "use client";
  2. import { useCallback, useEffect, useMemo, useRef, useState } from "react";
  3. import { createPortal } from "react-dom";
  4. import { MessageList } from "@/components/dashboard/MessageList";
  5. import { OnlineAgentsList, type OnlineAgent } from "./OnlineAgentsList";
  6. import { VisitorMessageInput } from "./VisitorMessageInput";
  7. import { Button } from "@/components/ui/button";
  8. import { Card } from "@/components/ui/card";
  9. import { websiteConfig } from "@/lib/website-config";
  10. import {
  11. ChatWebSocketPayload,
  12. MessageItem,
  13. MessagesReadPayload,
  14. TypingDraftPayload,
  15. } from "@/features/agent/types";
  16. import {
  17. fetchMessages,
  18. markMessagesRead,
  19. sendMessage,
  20. UploadFileResult,
  21. } from "@/features/agent/services/messageApi";
  22. import { initVisitorConversation } from "@/features/visitor/services/conversationApi";
  23. import { postWidgetOpen } from "@/features/visitor/services/analyticsApi";
  24. import { fetchOnlineAgents } from "@/features/visitor/services/visitorApi";
  25. import {
  26. fetchPublicAIModels,
  27. type AIConfig,
  28. } from "@/features/agent/services/aiConfigApi";
  29. import {
  30. fetchVisitorWidgetConfig,
  31. type VisitorWidgetConfig,
  32. } from "@/features/agent/services/embeddingConfigApi";
  33. import { TYPING_DRAFT_TTL_MS } from "@/lib/constants/typing-draft";
  34. import { useWebSocket } from "@/features/agent/hooks/useWebSocket";
  35. import type { WSMessage } from "@/lib/websocket";
  36. import { useSoundNotification } from "@/hooks/useSoundNotification";
  37. import { playNotificationSound } from "@/utils/sound";
  38. import { getAvatarUrl } from "@/utils/avatar";
  39. import { cn } from "@/lib/utils";
  40. import { Check, ChevronDown, Loader2 } from "lucide-react";
  41. import { useI18n } from "@/lib/i18n/provider";
  42. import { LanguageSwitcher } from "@/components/i18n/LanguageSwitcher";
  43. interface ChatWidgetProps {
  44. visitorId: number;
  45. isOpen: boolean;
  46. /** iframe 嵌入:铺满容器,不使用 fixed + portal */
  47. embedded?: boolean;
  48. onToggle: () => void;
  49. }
  50. function parseUserAgent(userAgent: string) {
  51. const ua = userAgent.toLowerCase();
  52. let browser = "Unknown";
  53. let os = "Unknown";
  54. if (ua.includes("edg/")) {
  55. browser = "Edge";
  56. } else if (ua.includes("chrome/")) {
  57. browser = "Chrome";
  58. } else if (ua.includes("firefox/")) {
  59. browser = "Firefox";
  60. } else if (ua.includes("safari/")) {
  61. browser = "Safari";
  62. }
  63. if (ua.includes("windows nt")) {
  64. os = "Windows";
  65. } else if (ua.includes("mac os x") || ua.includes("macintosh")) {
  66. os = "macOS";
  67. } else if (ua.includes("android")) {
  68. os = "Android";
  69. } else if (ua.includes("iphone") || ua.includes("ipad")) {
  70. os = "iOS";
  71. } else if (ua.includes("linux")) {
  72. os = "Linux";
  73. }
  74. return { browser, os };
  75. }
  76. /** 与顶栏(Header h-16 / md:h-20 + 间距)、底栏(bottom-20 / sm:bottom-24)对齐,矮视口下限制高度 */
  77. const CHAT_WIDGET_PANEL_MAX_H =
  78. "max-h-[min(680px,calc(100dvh-5rem-4.5rem-env(safe-area-inset-top,0px)))] sm:max-h-[min(680px,calc(100dvh-6rem-4.5rem-env(safe-area-inset-top,0px)))] md:max-h-[min(680px,calc(100dvh-6rem-5.5rem-env(safe-area-inset-top,0px)))]";
  79. const CHAT_WIDGET_PANEL_H =
  80. "h-[min(540px,calc(100dvh-5rem-4.5rem-env(safe-area-inset-top,0px)))] sm:h-[min(620px,calc(100dvh-6rem-4.5rem-env(safe-area-inset-top,0px)))] md:h-[min(680px,calc(100dvh-6rem-5.5rem-env(safe-area-inset-top,0px)))]";
  81. /** 视口偏矮时略收窄,避免「又矮又宽」的观感;大屏高度充足时仍为 420px */
  82. const CHAT_WIDGET_PANEL_WIDTH =
  83. "w-[min(420px,calc(100vw-1.5rem))] [@media(max-height:780px)]:w-[min(372px,calc(100vw-1.5rem))] [@media(max-height:680px)]:w-[min(340px,calc(100vw-1.5rem))]";
  84. const CHAT_WIDGET_PANEL_MAX_W =
  85. "max-w-[420px] [@media(max-height:780px)]:max-w-[372px] [@media(max-height:680px)]:max-w-[340px]";
  86. /**
  87. * 聊天小窗组件
  88. * 提供小窗形式的聊天界面,支持展开/收起
  89. */
  90. export function ChatWidget({
  91. visitorId,
  92. isOpen,
  93. embedded = false,
  94. onToggle,
  95. }: ChatWidgetProps) {
  96. const { t } = useI18n();
  97. const WEB_SEARCH_PREF_KEY = "visitor_widget_need_web_search";
  98. // 数据分析:每次由关→开上报一次小窗打开(供后台「小窗打开次数」统计)
  99. const prevIsOpenRef = useRef(false);
  100. useEffect(() => {
  101. if (!isOpen) {
  102. prevIsOpenRef.current = false;
  103. return;
  104. }
  105. if (!prevIsOpenRef.current && visitorId != null && visitorId > 0) {
  106. void postWidgetOpen(visitorId);
  107. }
  108. prevIsOpenRef.current = true;
  109. }, [isOpen, visitorId]);
  110. // ===== 状态管理 =====
  111. const [conversationId, setConversationId] = useState<number | null>(null);
  112. const [conversationStatus, setConversationStatus] = useState<string>("open");
  113. const [messages, setMessages] = useState<MessageItem[]>([]);
  114. const [loadingMessages, setLoadingMessages] = useState(true);
  115. const [sending, setSending] = useState(false);
  116. const [input, setInput] = useState("");
  117. const [chatMode, setChatMode] = useState<"human" | "ai">("human");
  118. const [initializing, setInitializing] = useState(false);
  119. const [selectedAIConfigId, setSelectedAIConfigId] = useState<
  120. number | undefined
  121. >(undefined);
  122. const [modelMenuOpen, setModelMenuOpen] = useState(false);
  123. const modelMenuRef = useRef<HTMLDivElement | null>(null);
  124. const [aiModels, setAiModels] = useState<AIConfig[]>([]);
  125. const [onlineAgents, setOnlineAgents] = useState<OnlineAgent[]>([]);
  126. const [loadingAgents, setLoadingAgents] = useState(false);
  127. /** AI 模式下发消息后等待回复时显示「正在输入」提示 */
  128. const [aiTyping, setAiTyping] = useState(false);
  129. const [agentTypingDraft, setAgentTypingDraft] = useState("");
  130. const [agentTypingSenderId, setAgentTypingSenderId] = useState<number | null>(null);
  131. /** 联网搜索:本回合是否使用联网(访客可勾选) */
  132. const [needWebSearch, setNeedWebSearch] = useState(false);
  133. /** 访客小窗配置(由配置页控制是否显示联网设置) */
  134. const [widgetConfig, setWidgetConfig] = useState<VisitorWidgetConfig | null>(null);
  135. const typingSeqRef = useRef(0);
  136. const typingTimerRef = useRef<NodeJS.Timeout | null>(null);
  137. // 声音通知开关(访客端)
  138. const { enabled: soundEnabled, toggle: toggleSound } = useSoundNotification(true);
  139. const noopHighlight = useCallback(() => {}, []);
  140. const shouldHideForVisitor = useCallback((msg: MessageItem) => {
  141. if ((msg.message_type ?? "") !== "system_message") return false;
  142. const content = (msg.content || "").trim().toLowerCase();
  143. // 访客侧隐藏来源/落地页埋点系统消息,仅客服端查看即可
  144. return (
  145. content.startsWith("visitor opened the page") ||
  146. content.startsWith("visitor came from")
  147. );
  148. }, []);
  149. const isMessageInCurrentMode = useCallback(
  150. (msg: MessageItem) => {
  151. const mode = (msg.chat_mode || "human").toLowerCase();
  152. return mode === chatMode;
  153. },
  154. [chatMode]
  155. );
  156. const selectedAIModel = useMemo(
  157. () => aiModels.find((m) => m.id === selectedAIConfigId) ?? null,
  158. [aiModels, selectedAIConfigId]
  159. );
  160. const agentAvatarMap = useMemo<Record<number, string>>(
  161. () =>
  162. Object.fromEntries(
  163. onlineAgents
  164. .filter((a) => a.id > 0 && Boolean(a.avatar_url))
  165. .map((a) => [a.id, a.avatar_url])
  166. ),
  167. [onlineAgents]
  168. );
  169. useEffect(() => {
  170. const onDocClick = (event: MouseEvent) => {
  171. if (!modelMenuRef.current) return;
  172. if (!modelMenuRef.current.contains(event.target as Node)) {
  173. setModelMenuOpen(false);
  174. }
  175. };
  176. document.addEventListener("mousedown", onDocClick);
  177. return () => document.removeEventListener("mousedown", onDocClick);
  178. }, []);
  179. // 加载在线客服列表
  180. const loadOnlineAgents = useCallback(async () => {
  181. setLoadingAgents(true);
  182. try {
  183. const agents = await fetchOnlineAgents();
  184. setOnlineAgents(agents);
  185. } catch (error) {
  186. console.error("加载在线客服列表失败:", error);
  187. } finally {
  188. setLoadingAgents(false);
  189. }
  190. }, []);
  191. // 当小窗打开时,加载在线客服列表
  192. useEffect(() => {
  193. if (isOpen) {
  194. loadOnlineAgents();
  195. // 定期刷新在线客服列表(每30秒)
  196. const interval = setInterval(loadOnlineAgents, 30000);
  197. return () => clearInterval(interval);
  198. }
  199. }, [isOpen, loadOnlineAgents]);
  200. // 当小窗打开时,拉取访客小窗配置(联网设置是否显示及来源)
  201. useEffect(() => {
  202. if (isOpen) {
  203. fetchVisitorWidgetConfig()
  204. .then(setWidgetConfig)
  205. .catch(() => setWidgetConfig(null));
  206. }
  207. }, [isOpen]);
  208. // 记住「联网搜索」开关状态(仅浏览器端)
  209. useEffect(() => {
  210. if (typeof window === "undefined") return;
  211. const saved = window.localStorage.getItem(WEB_SEARCH_PREF_KEY);
  212. if (saved === "true") setNeedWebSearch(true);
  213. if (saved === "false") setNeedWebSearch(false);
  214. }, []);
  215. useEffect(() => {
  216. if (typeof window === "undefined") return;
  217. window.localStorage.setItem(WEB_SEARCH_PREF_KEY, String(needWebSearch));
  218. }, [needWebSearch]);
  219. // 加载开放的 AI 模型列表(文本 + 生图),统一作为 AI 客服下的渠道
  220. useEffect(() => {
  221. async function loadModels() {
  222. try {
  223. const [textModels, imgModels] = await Promise.all([
  224. fetchPublicAIModels("text"),
  225. fetchPublicAIModels("image"),
  226. ]);
  227. const all = [...textModels, ...imgModels];
  228. setAiModels(all);
  229. if (all.length > 0) {
  230. setSelectedAIConfigId(all[0].id);
  231. }
  232. } catch (error) {
  233. console.error("加载 AI/生图模型列表失败:", error);
  234. }
  235. }
  236. loadModels();
  237. }, []);
  238. // 创建或恢复访客会话
  239. const initializeConversation = useCallback(
  240. async (id: number, mode: "human" | "ai", aiConfigId?: number) => {
  241. setInitializing(true);
  242. try {
  243. const { browser, os } = parseUserAgent(navigator.userAgent);
  244. const language =
  245. navigator.language ||
  246. (navigator.languages && navigator.languages[0]) ||
  247. "";
  248. const result = await initVisitorConversation({
  249. visitorId: id,
  250. website: window.location.href,
  251. referrer: document.referrer || "",
  252. browser,
  253. os,
  254. language,
  255. chatMode: mode,
  256. aiConfigId,
  257. });
  258. if (result.conversation_id) {
  259. setConversationId(result.conversation_id);
  260. setConversationStatus(result.status);
  261. setChatMode(mode);
  262. }
  263. } catch (error) {
  264. console.error("初始化对话失败:", error);
  265. alert("初始化对话失败,请重试");
  266. } finally {
  267. setInitializing(false);
  268. }
  269. },
  270. []
  271. );
  272. // 初始化默认对话(人工模式)
  273. useEffect(() => {
  274. if (visitorId !== null && !conversationId && !initializing && isOpen) {
  275. initializeConversation(visitorId, "human");
  276. }
  277. }, [visitorId, conversationId, initializing, isOpen, initializeConversation]);
  278. // 处理模式切换
  279. const handleModeSwitch = useCallback(
  280. (mode: "human" | "ai") => {
  281. if (visitorId === null || initializing) {
  282. return;
  283. }
  284. if (mode === "ai") {
  285. if (aiModels.length === 0) {
  286. alert("暂无可用的 AI 模型,请在后台「设置」-「AI 配置」中至少将一个模型设为「开放给访客」后再试。");
  287. return;
  288. }
  289. if (!selectedAIConfigId) {
  290. alert("请先选择一个 AI 模型");
  291. return;
  292. }
  293. }
  294. const configId = mode === "ai" ? selectedAIConfigId : undefined;
  295. initializeConversation(visitorId, mode, configId);
  296. },
  297. [visitorId, initializing, selectedAIConfigId, aiModels.length, initializeConversation]
  298. );
  299. // 标记客服消息已读
  300. const handleMarkAgentMessagesRead = useCallback(
  301. async (conversationIdParam?: number, readerIsAgentParam?: boolean) => {
  302. const targetConversationId = conversationIdParam ?? conversationId;
  303. const targetReaderIsAgent = readerIsAgentParam ?? false;
  304. if (!targetConversationId) {
  305. return;
  306. }
  307. const result = await markMessagesRead(
  308. targetConversationId,
  309. targetReaderIsAgent
  310. );
  311. if (!result || result.message_ids.length === 0) {
  312. return;
  313. }
  314. const idSet = new Set(result.message_ids);
  315. setMessages((prev) =>
  316. prev.map((msg) =>
  317. idSet.has(msg.id)
  318. ? {
  319. ...msg,
  320. is_read: true,
  321. read_at: result.read_at ?? msg.read_at ?? null,
  322. }
  323. : msg
  324. )
  325. );
  326. },
  327. [conversationId]
  328. );
  329. // 拉取历史消息(AI 模式时包含 AI 对话记录,人工模式时仅人工消息)
  330. const loadMessages = useCallback(async () => {
  331. if (!conversationId) {
  332. return;
  333. }
  334. setLoadingMessages(true);
  335. try {
  336. const includeAIMessages = chatMode === "ai";
  337. const data = await fetchMessages(conversationId, includeAIMessages);
  338. const normalizedMessages = data.map((msg) => ({
  339. ...msg,
  340. is_read: msg.is_read ?? false,
  341. read_at: msg.read_at ?? null,
  342. })).filter((msg) => !shouldHideForVisitor(msg) && isMessageInCurrentMode(msg));
  343. setMessages(normalizedMessages);
  344. } catch (error) {
  345. console.error("拉取消息失败:", error);
  346. } finally {
  347. setLoadingMessages(false);
  348. }
  349. }, [conversationId, chatMode, shouldHideForVisitor, isMessageInCurrentMode]);
  350. useEffect(() => {
  351. if (isOpen && conversationId) {
  352. loadMessages();
  353. }
  354. }, [isOpen, conversationId, loadMessages]);
  355. // 收到新消息时更新状态
  356. const handleNewMessage = useCallback(
  357. (message: MessageItem) => {
  358. if (!conversationId || message.conversation_id !== conversationId) {
  359. return;
  360. }
  361. if (shouldHideForVisitor(message)) {
  362. return;
  363. }
  364. if (!isMessageInCurrentMode(message)) {
  365. return;
  366. }
  367. // 如果是客服发送的消息(不是访客自己发送的)且开启声音,播放提示音
  368. if (message.sender_is_agent && soundEnabled) {
  369. playNotificationSound();
  370. }
  371. setMessages((prev) => {
  372. // 检查是否已存在相同ID的消息(真实消息)
  373. const exists = prev.some((item) => item.id === message.id);
  374. if (exists) {
  375. // 更新已存在的消息,确保创建新数组引用
  376. const updated = prev.map((msg) =>
  377. msg.id === message.id
  378. ? {
  379. ...msg,
  380. ...message,
  381. is_read: message.is_read ?? msg.is_read ?? false,
  382. read_at: message.read_at ?? msg.read_at ?? null,
  383. }
  384. : msg
  385. );
  386. // 检查是否有实际变化,如果没有变化也返回新数组引用
  387. const hasChange = updated.some((msg, idx) => {
  388. const oldMsg = prev[idx];
  389. return !oldMsg || msg.id !== oldMsg.id || JSON.stringify(msg) !== JSON.stringify(oldMsg);
  390. });
  391. if (!hasChange) {
  392. return [...updated]; // 强制创建新数组引用
  393. }
  394. return updated;
  395. }
  396. // 如果是访客自己发送的消息(sender_is_agent = false),移除对应的临时消息
  397. // 临时消息的 ID 是 Date.now(),通常大于 1000000000000
  398. // 真实消息的 ID 通常较小
  399. const isVisitorMessage = !message.sender_is_agent;
  400. if (isVisitorMessage) {
  401. // 移除所有临时消息(ID 大于 1000000000000)和已存在的相同真实消息(如果有)
  402. // 这样可以避免临时消息和真实消息重复显示
  403. const filteredPrev = prev.filter((msg) =>
  404. msg.id < 1000000000000 && msg.id !== message.id
  405. );
  406. // 检查过滤后的数组和原数组是否不同,或者消息ID是否变化
  407. const hasTempMessage = prev.some((msg) => msg.id >= 1000000000000);
  408. const hasSameMessage = prev.some((msg) => msg.id === message.id);
  409. // 如果列表没有变化(没有临时消息需要移除,且消息已存在),仍然创建新数组引用
  410. if (!hasTempMessage && hasSameMessage) {
  411. // 即使没有变化,也创建新数组引用,确保 React 检测到变化
  412. return [...prev];
  413. }
  414. // 确保新消息不在列表中,然后添加
  415. // 检查过滤后的列表是否已包含该消息
  416. const alreadyInFiltered = filteredPrev.some((msg) => msg.id === message.id);
  417. if (alreadyInFiltered) {
  418. // 即使已存在,也创建新数组引用以确保渲染
  419. return [...filteredPrev];
  420. }
  421. const newMessages = [
  422. ...filteredPrev,
  423. {
  424. ...message,
  425. is_read: message.is_read ?? false,
  426. },
  427. ];
  428. // 强制创建新数组引用,确保 React 检测到变化
  429. return newMessages;
  430. }
  431. // 其他消息(客服发送的)直接添加
  432. // 检查是否已存在,避免重复添加
  433. const alreadyExists = prev.some((msg) => msg.id === message.id);
  434. if (alreadyExists) {
  435. // 即使消息已存在,也创建新数组引用,确保 React 检测到变化
  436. return [...prev];
  437. }
  438. const newMessages = [
  439. ...prev,
  440. {
  441. ...message,
  442. is_read: message.is_read ?? false,
  443. },
  444. ];
  445. // 强制创建新数组引用,确保 React 检测到变化
  446. return newMessages;
  447. });
  448. },
  449. [conversationId, shouldHideForVisitor, isMessageInCurrentMode]
  450. );
  451. // 处理 WebSocket 的已读事件
  452. const handleMessagesReadEvent = useCallback(
  453. (payload: MessagesReadPayload) => {
  454. if (!conversationId) {
  455. return;
  456. }
  457. const payloadConversationId = payload?.conversation_id;
  458. if (payloadConversationId && payloadConversationId !== conversationId) {
  459. return;
  460. }
  461. if (payload?.reader_is_agent !== true) {
  462. return;
  463. }
  464. const ids = Array.isArray(payload?.message_ids)
  465. ? payload.message_ids
  466. : [];
  467. if (ids.length === 0) {
  468. return;
  469. }
  470. const idSet = new Set(ids);
  471. const readAt = payload?.read_at;
  472. setMessages((prev) =>
  473. prev.map((msg) =>
  474. idSet.has(msg.id) && !msg.sender_is_agent
  475. ? {
  476. ...msg,
  477. is_read: true,
  478. read_at: readAt ?? msg.read_at ?? null,
  479. }
  480. : msg
  481. )
  482. );
  483. },
  484. [conversationId]
  485. );
  486. const handleWebSocketMessage = useCallback(
  487. (event: WSMessage<ChatWebSocketPayload>) => {
  488. if (!event) {
  489. return;
  490. }
  491. if (event.type === "new_message" && event.data) {
  492. const msg = event.data as MessageItem;
  493. handleNewMessage(msg);
  494. if (msg.sender_is_agent) {
  495. setAgentTypingDraft("");
  496. }
  497. // AI 模式下收到对方(客服/AI)回复时关闭「正在输入」提示
  498. if (chatMode === "ai" && msg.sender_is_agent) {
  499. setAiTyping(false);
  500. }
  501. } else if (event.type === "messages_read") {
  502. const payload = event.data as MessagesReadPayload;
  503. if (!payload.conversation_id && event.conversation_id) {
  504. payload.conversation_id = event.conversation_id;
  505. }
  506. handleMessagesReadEvent(payload);
  507. } else if (event.type === "typing_draft" && event.data) {
  508. const payload = event.data as TypingDraftPayload;
  509. // 访客侧只展示客服草稿。
  510. if (!payload.sender_is_agent) {
  511. return;
  512. }
  513. const text = typeof payload.text === "string" ? payload.text : "";
  514. setAgentTypingDraft(text);
  515. setAgentTypingSenderId(
  516. typeof payload.sender_id === "number" ? payload.sender_id : null
  517. );
  518. if (typingTimerRef.current) {
  519. clearTimeout(typingTimerRef.current);
  520. }
  521. typingTimerRef.current = setTimeout(() => {
  522. setAgentTypingDraft("");
  523. setAgentTypingSenderId(null);
  524. }, TYPING_DRAFT_TTL_MS);
  525. } else if (event.type === "typing_stop") {
  526. const payload = (event.data || {}) as TypingDraftPayload;
  527. if (!payload.sender_is_agent) {
  528. return;
  529. }
  530. setAgentTypingDraft("");
  531. setAgentTypingSenderId(null);
  532. if (typingTimerRef.current) {
  533. clearTimeout(typingTimerRef.current);
  534. typingTimerRef.current = null;
  535. }
  536. }
  537. },
  538. [handleMessagesReadEvent, handleNewMessage, chatMode]
  539. );
  540. const { send: sendWebSocketEvent } = useWebSocket<ChatWebSocketPayload>({
  541. conversationId,
  542. enabled: Boolean(conversationId) && isOpen,
  543. isVisitor: true,
  544. onMessage: handleWebSocketMessage,
  545. onError: (error) => {
  546. console.error("WebSocket 连接错误(访客端):", error);
  547. },
  548. });
  549. const sendTypingDraft = useCallback(
  550. (text: string) => {
  551. if (!conversationId) {
  552. return;
  553. }
  554. const content = text.slice(0, 300);
  555. if (!content.trim()) {
  556. sendWebSocketEvent("typing_stop", { sender_is_agent: false });
  557. return;
  558. }
  559. typingSeqRef.current += 1;
  560. sendWebSocketEvent("typing_draft", {
  561. sender_is_agent: false,
  562. text: content,
  563. seq: typingSeqRef.current,
  564. });
  565. },
  566. [conversationId, sendWebSocketEvent]
  567. );
  568. const sendTypingStop = useCallback(() => {
  569. if (!conversationId) {
  570. return;
  571. }
  572. sendWebSocketEvent("typing_stop", { sender_is_agent: false });
  573. }, [conversationId, sendWebSocketEvent]);
  574. useEffect(() => {
  575. if (!conversationId || !isOpen || chatMode !== "human") {
  576. return;
  577. }
  578. const timer = setTimeout(() => {
  579. if (input.trim()) {
  580. sendTypingDraft(input);
  581. } else {
  582. sendTypingStop();
  583. }
  584. }, 350);
  585. return () => clearTimeout(timer);
  586. }, [chatMode, conversationId, input, isOpen, sendTypingDraft, sendTypingStop]);
  587. useEffect(() => {
  588. if (!isOpen || chatMode !== "human") {
  589. setAgentTypingDraft("");
  590. setAgentTypingSenderId(null);
  591. }
  592. }, [chatMode, isOpen]);
  593. useEffect(() => {
  594. return () => {
  595. if (typingTimerRef.current) {
  596. clearTimeout(typingTimerRef.current);
  597. }
  598. sendTypingStop();
  599. };
  600. }, [sendTypingStop]);
  601. const handleSendMessage = useCallback(
  602. async (fileInfo?: UploadFileResult) => {
  603. if (!conversationId || sending) {
  604. return;
  605. }
  606. if (!input.trim() && !fileInfo) {
  607. return;
  608. }
  609. const messageContent = input.trim();
  610. // 乐观更新:立即将消息添加到本地状态(临时消息,稍后会被服务器返回的真实消息替换)
  611. const tempMessage: MessageItem = {
  612. id: Date.now(), // 临时ID,发送成功后会被真实ID替换
  613. conversation_id: conversationId,
  614. content: messageContent,
  615. sender_id: visitorId || 0,
  616. sender_is_agent: false,
  617. message_type: fileInfo?.file_type === "image" ? "image" : fileInfo?.file_type === "document" ? "document" : "text",
  618. is_read: false,
  619. read_at: null,
  620. created_at: new Date().toISOString(),
  621. file_url: fileInfo?.file_url || null,
  622. file_name: fileInfo?.file_name || null,
  623. file_size: fileInfo?.file_size || null,
  624. mime_type: fileInfo?.mime_type || null,
  625. chat_mode: chatMode,
  626. };
  627. // 立即添加到消息列表
  628. setMessages((prev) => [...prev, tempMessage]);
  629. setInput("");
  630. sendTypingStop();
  631. setSending(true);
  632. if (chatMode === "ai") {
  633. setAiTyping(true);
  634. }
  635. try {
  636. await sendMessage({
  637. conversationId,
  638. content: messageContent,
  639. senderIsAgent: false,
  640. fileUrl: fileInfo?.file_url,
  641. fileType: fileInfo?.file_type as "image" | "document" | undefined,
  642. fileName: fileInfo?.file_name,
  643. fileSize: fileInfo?.file_size,
  644. mimeType: fileInfo?.mime_type,
  645. needWebSearch: chatMode === "ai" ? needWebSearch : undefined,
  646. useWebSearch: chatMode === "ai" && needWebSearch ? true : undefined,
  647. });
  648. // 不在这里调用 loadMessages,完全依赖 WebSocket 来接收新消息
  649. // WebSocket 会收到服务器广播的消息,包括自己发送的消息
  650. // 这样可以避免 loadMessages 覆盖 WebSocket 的更新
  651. } catch (error) {
  652. // 发送失败,移除临时消息
  653. setMessages((prev) => prev.filter((msg) => msg.id !== tempMessage.id));
  654. if (chatMode === "ai") setAiTyping(false);
  655. console.error("❌ 发送消息失败:", error);
  656. alert((error as Error).message || "发送消息失败,请稍后重试");
  657. // 恢复输入内容
  658. setInput(messageContent);
  659. } finally {
  660. setSending(false);
  661. }
  662. },
  663. [conversationId, input, sending, visitorId, chatMode, needWebSearch, sendTypingStop, widgetConfig]
  664. );
  665. // 如果不打开,不渲染内容
  666. if (!isOpen) {
  667. return null;
  668. }
  669. const panel = (
  670. <Card
  671. className={cn(
  672. "flex flex-col overflow-hidden bg-white text-slate-900",
  673. embedded
  674. ? "h-full w-full min-h-0 rounded-none border-0 shadow-none ring-0"
  675. : cn(
  676. "fixed bottom-20 right-4 sm:bottom-24 sm:right-6 shadow-[0_24px_60px_-24px_rgba(2,6,23,0.35)] z-40 border border-slate-200 rounded-2xl ring-1 ring-slate-200/80",
  677. CHAT_WIDGET_PANEL_MAX_W,
  678. CHAT_WIDGET_PANEL_WIDTH,
  679. CHAT_WIDGET_PANEL_MAX_H,
  680. CHAT_WIDGET_PANEL_H
  681. )
  682. )}
  683. >
  684. {/* 头部:回归品牌蓝色系,保持轻量与一致 */}
  685. <div className="bg-gradient-to-r from-[#2563eb] to-[#3b82f6] border-b border-blue-300/40 px-4 py-3.5 flex items-center justify-between rounded-t-2xl">
  686. <div className="flex items-center gap-2.5 min-w-0">
  687. <div className="w-8 h-8 rounded-xl bg-white/20 backdrop-blur-sm flex items-center justify-center ring-1 ring-white/30">
  688. <svg
  689. className="w-5 h-5 text-white/90"
  690. fill="none"
  691. stroke="currentColor"
  692. viewBox="0 0 24 24"
  693. >
  694. <path
  695. strokeLinecap="round"
  696. strokeLinejoin="round"
  697. strokeWidth={2}
  698. d="M8 12h.01M12 12h.01M16 12h.01M21 12c0 4.418-4.03 8-9 8a9.863 9.863 0 01-4.255-.949L3 20l1.395-3.72C3.512 15.042 3 13.574 3 12c0-4.418 4.03-8 9-8s9 3.582 9 8z"
  699. />
  700. </svg>
  701. </div>
  702. <h2 className="text-base font-bold text-white truncate">{t("chat.title")}</h2>
  703. </div>
  704. <div className="flex items-center gap-2">
  705. <LanguageSwitcher
  706. variant="ghost"
  707. size="sm"
  708. className="text-white/90 hover:text-white hover:bg-white/20 h-8 px-2 rounded-lg transition-colors"
  709. />
  710. {/* 声音开关按钮 */}
  711. <Button
  712. variant="ghost"
  713. size="sm"
  714. onClick={toggleSound}
  715. className="text-white/90 hover:text-white hover:bg-white/20 h-8 w-8 p-0 rounded-lg transition-colors"
  716. aria-label={soundEnabled ? "关闭声音" : "开启声音"}
  717. title={soundEnabled ? "关闭声音提示" : "开启声音提示"}
  718. >
  719. {soundEnabled ? (
  720. <svg
  721. className="w-5 h-5"
  722. fill="none"
  723. stroke="currentColor"
  724. viewBox="0 0 24 24"
  725. >
  726. <path
  727. strokeLinecap="round"
  728. strokeLinejoin="round"
  729. strokeWidth={2}
  730. d="M15.536 8.464a5 5 0 010 7.072m2.828-9.9a9 9 0 010 12.728M5.586 15H4a1 1 0 01-1-1v-4a1 1 0 011-1h1.586l4.707-4.707C10.923 3.663 12 4.109 12 5v14c0 .891-1.077 1.337-1.707.707L5.586 15z"
  731. />
  732. </svg>
  733. ) : (
  734. <svg
  735. className="w-5 h-5"
  736. fill="none"
  737. stroke="currentColor"
  738. viewBox="0 0 24 24"
  739. >
  740. <path
  741. strokeLinecap="round"
  742. strokeLinejoin="round"
  743. strokeWidth={2}
  744. d="M5.586 15H4a1 1 0 01-1-1v-4a1 1 0 011-1h1.586l4.707-4.707C10.923 3.663 12 4.109 12 5v14c0 .891-1.077 1.337-1.707.707L5.586 15z"
  745. />
  746. <path
  747. strokeLinecap="round"
  748. strokeLinejoin="round"
  749. strokeWidth={2}
  750. d="M17 14l2-2m0 0l2-2m-2 2l-2-2m2 2l2 2"
  751. />
  752. </svg>
  753. )}
  754. </Button>
  755. {/* GitHub 链接按钮 */}
  756. <Button
  757. variant="ghost"
  758. size="sm"
  759. asChild
  760. className="text-white/90 hover:text-white hover:bg-white/20 h-8 w-8 p-0 rounded-lg transition-colors"
  761. aria-label="GitHub"
  762. title="查看 GitHub 仓库"
  763. >
  764. <a
  765. href={websiteConfig.github.repo}
  766. target="_blank"
  767. rel="noopener noreferrer"
  768. >
  769. <svg
  770. className="w-5 h-5"
  771. fill="currentColor"
  772. viewBox="0 0 24 24"
  773. >
  774. <path d="M12 0c-6.626 0-12 5.373-12 12 0 5.302 3.438 9.8 8.207 11.387.599.111.793-.261.793-.577v-2.234c-3.338.726-4.033-1.416-4.033-1.416-.546-1.387-1.333-1.756-1.333-1.756-1.089-.745.083-.729.083-.729 1.205.084 1.839 1.237 1.839 1.237 1.07 1.834 2.807 1.304 3.492.997.107-.775.418-1.305.762-1.604-2.665-.305-5.467-1.334-5.467-5.931 0-1.311.469-2.381 1.236-3.221-.124-.303-.535-1.524.117-3.176 0 0 1.008-.322 3.301 1.23.957-.266 1.983-.399 3.003-.404 1.02.005 2.047.138 3.006.404 2.291-1.552 3.297-1.23 3.297-1.23.653 1.653.242 2.874.118 3.176.77.84 1.235 1.911 1.235 3.221 0 4.609-2.807 5.624-5.479 5.921.43.372.823 1.102.823 2.222v3.293c0 .319.192.694.801.576 4.765-1.589 8.199-6.086 8.199-11.386 0-6.627-5.373-12-12-12z" />
  775. </svg>
  776. </a>
  777. </Button>
  778. </div>
  779. </div>
  780. {/* 模式切换和在线客服列表 */}
  781. <div className="px-4 py-3 border-b border-slate-200 bg-slate-50">
  782. {/* 模式切换按钮 */}
  783. <div className="flex items-center gap-2 mb-3 justify-center flex-wrap">
  784. <Button
  785. variant={chatMode === "human" ? "default" : "outline"}
  786. size="sm"
  787. onClick={() => handleModeSwitch("human")}
  788. disabled={initializing}
  789. className={
  790. chatMode === "human"
  791. ? "bg-blue-600 text-white shadow-sm hover:bg-blue-500 transition-colors border border-blue-600"
  792. : "bg-white text-slate-700 hover:text-slate-900 hover:bg-slate-100 border border-slate-300"
  793. }
  794. >
  795. {t("chat.mode.human")}
  796. </Button>
  797. <Button
  798. variant={chatMode === "ai" ? "default" : "outline"}
  799. size="sm"
  800. onClick={() => handleModeSwitch("ai")}
  801. disabled={initializing}
  802. title={aiModels.length === 0 ? "暂无可用的 AI/绘画模型,请在后台设置中开放" : undefined}
  803. className={
  804. chatMode === "ai"
  805. ? "bg-blue-600 text-white shadow-sm hover:bg-blue-500 transition-colors border border-blue-600"
  806. : "bg-white text-slate-700 hover:text-slate-900 hover:bg-slate-100 border border-slate-300"
  807. }
  808. >
  809. {t("chat.mode.ai")}
  810. </Button>
  811. </div>
  812. {/* 模型选择已下沉到输入区发送按钮左侧(仅 AI 模式显示) */}
  813. {/* 在线客服列表(仅人工模式显示) */}
  814. {chatMode === "human" && (
  815. <OnlineAgentsList
  816. agents={onlineAgents}
  817. onAgentClick={(agent) => {
  818. // 点击客服可以切换对话(如果需要的话)
  819. }}
  820. />
  821. )}
  822. </div>
  823. {/* 消息列表 */}
  824. <div className="flex-1 overflow-hidden min-h-0 bg-slate-50">
  825. <MessageList
  826. key={`messages-${conversationId}-${chatMode}`}
  827. messages={messages}
  828. loading={loadingMessages}
  829. highlightKeyword=""
  830. onHighlightClear={noopHighlight}
  831. currentUserIsAgent={false}
  832. disableAutoScroll={false}
  833. conversationId={conversationId}
  834. onMarkMessagesRead={handleMarkAgentMessagesRead}
  835. leftAvatarBySenderId={chatMode === "human" ? agentAvatarMap : undefined}
  836. bottomSlot={
  837. <>
  838. {chatMode === "human" && agentTypingDraft ? (
  839. <div className="flex justify-start mt-2">
  840. <div className="w-7 h-7 rounded-full overflow-hidden bg-slate-200 border border-slate-300 flex-shrink-0">
  841. {(() => {
  842. const draftAvatar =
  843. agentTypingSenderId != null
  844. ? getAvatarUrl(agentAvatarMap[agentTypingSenderId])
  845. : null;
  846. return draftAvatar ? (
  847. <img
  848. src={draftAvatar}
  849. alt="客服头像"
  850. className="w-full h-full object-cover"
  851. />
  852. ) : (
  853. <div className="w-full h-full flex items-center justify-center text-[10px] text-slate-600">
  854. </div>
  855. );
  856. })()}
  857. </div>
  858. <div className="px-3.5 py-2.5 rounded-[18px] rounded-bl-md bg-slate-100/80 border border-solid border-slate-300 shadow-[0_1px_3px_rgba(15,23,42,0.04)] text-sm text-slate-500 max-w-[72%] break-words">
  859. <span>{agentTypingDraft}</span>
  860. <span className="inline-flex items-center ml-1 align-middle">
  861. <span className="w-1 h-1 rounded-full bg-slate-400 animate-bounce [animation-duration:1.2s]" />
  862. <span className="w-1 h-1 rounded-full bg-slate-400 animate-bounce [animation-duration:1.2s] [animation-delay:0.15s] mx-0.5" />
  863. <span className="w-1 h-1 rounded-full bg-slate-400 animate-bounce [animation-duration:1.2s] [animation-delay:0.3s]" />
  864. </span>
  865. </div>
  866. </div>
  867. ) : null}
  868. {chatMode === "ai" && aiTyping ? (
  869. <div className="flex justify-start mt-2">
  870. <div className="inline-flex items-center gap-2 px-4 py-2 rounded-2xl rounded-bl-none bg-white border border-slate-200 shadow-sm text-sm text-slate-500">
  871. <Loader2 className="w-4 h-4 animate-spin flex-shrink-0" />
  872. <span>AI 正在思考...</span>
  873. </div>
  874. </div>
  875. ) : null}
  876. </>
  877. }
  878. />
  879. </div>
  880. {/* 消息输入框 */}
  881. <div className="border-t border-slate-200 bg-slate-50 rounded-b-2xl px-3 pt-2 pb-2.5">
  882. <VisitorMessageInput
  883. value={input}
  884. onChange={setInput}
  885. onSubmit={handleSendMessage}
  886. sending={sending}
  887. conversationId={conversationId ?? undefined}
  888. toolsSlot={
  889. chatMode === "ai" && (widgetConfig?.web_search_enabled ?? false) ? (
  890. <button
  891. type="button"
  892. onClick={() => setNeedWebSearch((v) => !v)}
  893. className={`inline-flex items-center rounded-full border px-2.5 py-1 text-xs transition-colors ${
  894. needWebSearch
  895. ? "border-blue-300 bg-blue-50 text-blue-700"
  896. : "border-slate-300 bg-white text-slate-600 hover:bg-slate-50"
  897. }`}
  898. aria-pressed={needWebSearch}
  899. >
  900. 联网搜索
  901. </button>
  902. ) : null
  903. }
  904. submitLeftSlot={
  905. chatMode === "ai" && aiModels.length > 0 ? (
  906. <div className="relative" ref={modelMenuRef}>
  907. <button
  908. type="button"
  909. onClick={() => setModelMenuOpen((v) => !v)}
  910. disabled={initializing || sending}
  911. className="h-8 inline-flex items-center gap-1 rounded-full border border-slate-300 bg-white px-2.5 text-xs text-slate-700 hover:border-blue-400 focus:outline-none focus:ring-2 focus:ring-blue-200 transition-colors disabled:opacity-50"
  912. title="选择模型"
  913. >
  914. {selectedAIModel?.model_type === "image" ? "绘画" : "文本"}
  915. <ChevronDown className="w-3.5 h-3.5" />
  916. </button>
  917. {modelMenuOpen && (
  918. <div className="absolute bottom-10 -right-10 z-20 w-[280px] rounded-lg border border-slate-200 bg-white shadow-lg p-1">
  919. {aiModels.map((model) => {
  920. const active = model.id === selectedAIConfigId;
  921. return (
  922. <button
  923. key={model.id}
  924. type="button"
  925. className={`w-full px-2.5 py-2 text-left rounded-md flex items-start justify-between gap-2 ${
  926. active ? "bg-blue-50 text-blue-700" : "text-slate-700 hover:bg-slate-50"
  927. }`}
  928. onClick={() => {
  929. setSelectedAIConfigId(model.id);
  930. setModelMenuOpen(false);
  931. if (visitorId) initializeConversation(visitorId, "ai", model.id);
  932. }}
  933. >
  934. <span className="min-w-0">
  935. <div className="text-xs font-medium leading-4">
  936. {model.model_type === "image" ? "绘画" : "文本"}
  937. </div>
  938. <div className="text-[11px] leading-4 text-slate-500 break-all">
  939. {model.provider} - {model.model}
  940. </div>
  941. </span>
  942. {active ? <Check className="w-3.5 h-3.5 ml-2 flex-shrink-0" /> : null}
  943. </button>
  944. );
  945. })}
  946. </div>
  947. )}
  948. </div>
  949. ) : null
  950. }
  951. />
  952. </div>
  953. </Card>
  954. );
  955. if (embedded) {
  956. return panel;
  957. }
  958. // 挂到 body,避免页面内祖先的 transform/filter/backdrop-filter 在 Chrome 等浏览器中
  959. // 成为 fixed 定位的包含块,导致小窗错位到视口中上部而右下角按钮仍正常。
  960. if (typeof document === "undefined") {
  961. return null;
  962. }
  963. return createPortal(panel, document.body);
  964. }