ChatWidget.tsx 38 KB

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