ChatWidget.tsx 38 KB

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