ChatWidget.tsx 39 KB

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