DashboardShell.tsx 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422
  1. "use client";
  2. import { useCallback, useEffect, useMemo, useState } from "react";
  3. import { usePathname, useRouter, useSearchParams } from "next/navigation";
  4. import { useAuth } from "@/features/agent/hooks/useAuth";
  5. import { useConversations } from "@/features/agent/hooks/useConversations";
  6. import { useMessages } from "@/features/agent/hooks/useMessages";
  7. import { initInternalConversation } from "@/features/agent/services/conversationApi";
  8. import { closeConversation } from "@/features/agent/services/conversationApi";
  9. import { toast } from "@/hooks/useToast";
  10. import { useProfile } from "@/features/agent/hooks/useProfile";
  11. import { Profile } from "@/features/agent/types";
  12. import { ResponsiveLayout } from "@/components/layout";
  13. import { LAYOUT } from "@/lib/constants/breakpoints";
  14. import {
  15. getPageFromSearchParams,
  16. getAgentPage,
  17. } from "@/lib/constants/agent-pages";
  18. import { Loader2 } from "lucide-react";
  19. import { ChatHeader } from "./ChatHeader";
  20. import { ConversationSidebar } from "./ConversationSidebar";
  21. import { MessageInput } from "./MessageInput";
  22. import { MessageList } from "./MessageList";
  23. import { Checkbox } from "@/components/ui/checkbox";
  24. import { Label } from "@/components/ui/label";
  25. import { NavigationSidebar, type NavigationPage } from "./NavigationSidebar";
  26. import { ProfileModal } from "./ProfileModal";
  27. import { VisitorDetailPanel } from "./VisitorDetailPanel";
  28. import { useSoundNotification } from "@/hooks/useSoundNotification";
  29. import { usePageTitle } from "@/hooks/usePageTitle";
  30. import { reportFrontendLog } from "@/features/agent/services/systemLogApi";
  31. export function DashboardShell() {
  32. const pathname = usePathname();
  33. const router = useRouter();
  34. const searchParams = useSearchParams();
  35. const currentPage = getPageFromSearchParams(searchParams);
  36. // 登录状态:负责从本地存储读取客服信息,并提供登出方法
  37. const { agent, loading: authLoading, logout } = useAuth();
  38. // 前端全局错误上报(最小可用:window error + promise rejection)
  39. useEffect(() => {
  40. const onError = (ev: ErrorEvent) => {
  41. void reportFrontendLog({
  42. level: "error",
  43. category: "frontend",
  44. event: "window_error",
  45. message: ev.message || "window error",
  46. meta: {
  47. filename: ev.filename,
  48. lineno: ev.lineno,
  49. colno: ev.colno,
  50. },
  51. });
  52. };
  53. const onRejection = (ev: PromiseRejectionEvent) => {
  54. const reason = String(ev.reason ?? "unhandled rejection");
  55. void reportFrontendLog({
  56. level: "error",
  57. category: "frontend",
  58. event: "unhandled_rejection",
  59. message: reason.slice(0, 500),
  60. });
  61. };
  62. window.addEventListener("error", onError);
  63. window.addEventListener("unhandledrejection", onRejection);
  64. return () => {
  65. window.removeEventListener("error", onError);
  66. window.removeEventListener("unhandledrejection", onRejection);
  67. };
  68. }, []);
  69. // 个人资料状态
  70. const [profileModalOpen, setProfileModalOpen] = useState(false);
  71. const {
  72. profile,
  73. loading: profileLoading,
  74. refresh: refreshProfile,
  75. update: updateProfile,
  76. upload: uploadAvatar,
  77. } = useProfile({
  78. userId: agent?.id ?? null,
  79. enabled: Boolean(agent?.id),
  80. });
  81. // 会话过滤状态
  82. const [conversationFilter, setConversationFilter] = useState<"all" | "mine" | "others">("all");
  83. const [conversationStatus, setConversationStatus] = useState<"open" | "closed">("open");
  84. // 声音通知开关(客服端)
  85. const { enabled: soundEnabled, toggle: toggleSound } = useSoundNotification(false);
  86. const currentPageMeta = getAgentPage(currentPage);
  87. const isInternalChat = currentPage === "internal-chat";
  88. const isChatPage = currentPageMeta?.isChatPage ?? false;
  89. // 会话状态:访客对话或内部对话(知识库测试)根据 currentPage 切换
  90. const {
  91. conversations,
  92. filteredConversations,
  93. selectedConversationId,
  94. searchQuery,
  95. loading,
  96. isInitialLoad,
  97. setSearchQuery,
  98. selectConversation,
  99. updateConversation,
  100. refresh: refreshConversations,
  101. hasConversation,
  102. } = useConversations({
  103. agentId: agent?.id ?? null,
  104. filter: conversationFilter,
  105. listType: isInternalChat ? "internal" : "visitor",
  106. status: conversationStatus,
  107. });
  108. // 计算总未读消息数
  109. const totalUnreadCount = useMemo(() => {
  110. return conversations.reduce((sum, conv) => sum + (conv.unread_count ?? 0), 0);
  111. }, [conversations]);
  112. // 更新页面标题显示未读消息数
  113. usePageTitle(totalUnreadCount, "AI-CS");
  114. // 输入框内容与搜索高亮关键字
  115. const [messageInput, setMessageInput] = useState("");
  116. const [highlightKeyword, setHighlightKeyword] = useState("");
  117. // 当前选中的会话信息,供右侧访客详情展示
  118. const selectedConversation = useMemo(
  119. () =>
  120. conversations.find(
  121. (conversation) => conversation.id === selectedConversationId
  122. ) ?? null,
  123. [conversations, selectedConversationId]
  124. );
  125. // 消息层:负责消息列表、未读状态、访客详情以及 WebSocket
  126. const {
  127. messages,
  128. loadingMessages,
  129. sending,
  130. conversationDetail,
  131. refreshConversationDetail,
  132. refreshMessages,
  133. sendMessage,
  134. markMessagesAsRead,
  135. updateContactInfo,
  136. includeAIMessages,
  137. toggleAIMessages,
  138. aiThinking,
  139. needWebSearch,
  140. setNeedWebSearch,
  141. } = useMessages({
  142. conversationId: selectedConversationId,
  143. agentId: agent?.id ?? null,
  144. updateConversation,
  145. refreshConversations,
  146. hasConversation,
  147. soundEnabled,
  148. forceIncludeAIMessages: isInternalChat,
  149. });
  150. // 左侧选择会话时,记录关键字用于消息高亮
  151. const handleConversationSelect = useCallback(
  152. (conversationId: number) => {
  153. if (searchQuery.trim()) {
  154. setHighlightKeyword(searchQuery.trim());
  155. } else {
  156. setHighlightKeyword("");
  157. }
  158. selectConversation(conversationId);
  159. },
  160. [searchQuery, selectConversation]
  161. );
  162. // 发送消息:调用 service 后清空输入框
  163. const handleSendMessage = useCallback(async (fileInfo?: { file_url: string; file_type: string; file_name: string; file_size: number; mime_type: string }) => {
  164. const content = messageInput.trim();
  165. try {
  166. await sendMessage(content, fileInfo);
  167. setMessageInput("");
  168. } catch (error) {
  169. toast.error((error as Error).message);
  170. }
  171. }, [messageInput, sendMessage]);
  172. // 标记当前会话全部消息为已读
  173. const handleMarkAllRead = useCallback(() => {
  174. if (selectedConversationId) {
  175. markMessagesAsRead(selectedConversationId, true);
  176. }
  177. }, [markMessagesAsRead, selectedConversationId]);
  178. const handleCloseConversation = useCallback(async () => {
  179. if (!selectedConversationId) return;
  180. try {
  181. await closeConversation(selectedConversationId);
  182. toast.success("已关闭会话");
  183. // 清空选中并刷新列表/详情
  184. selectConversation(null);
  185. refreshConversations();
  186. } catch (e) {
  187. toast.error((e as Error).message || "关闭会话失败");
  188. }
  189. }, [refreshConversations, selectConversation, selectedConversationId]);
  190. // 手动刷新消息与访客详情
  191. const handleRefreshChat = useCallback(() => {
  192. if (!selectedConversationId) return;
  193. refreshMessages(selectedConversationId);
  194. refreshConversationDetail(selectedConversationId);
  195. }, [refreshConversationDetail, refreshMessages, selectedConversationId]);
  196. // 单独刷新访客详情
  197. const handleRefreshVisitor = useCallback(() => {
  198. if (!selectedConversationId) return;
  199. refreshConversationDetail(selectedConversationId);
  200. }, [refreshConversationDetail, selectedConversationId]);
  201. // 当前会话未读数(优先使用详情返回的数据)
  202. const selectedUnreadCount =
  203. conversationDetail?.unread_count ??
  204. selectedConversation?.unread_count ??
  205. 0;
  206. // 3 秒后清除搜索高亮
  207. const clearHighlight = useCallback(() => {
  208. setHighlightKeyword("");
  209. }, []);
  210. // 处理个人资料更新
  211. const handleProfileUpdate = useCallback(
  212. (updated: Profile) => {
  213. // 个人资料更新后,刷新缓存(这里可以通过更新 agent 状态来触发UI更新)
  214. refreshProfile();
  215. },
  216. [refreshProfile]
  217. );
  218. // 处理导航切换:更新 URL ?page=,与访客端路由一致,刷新后保留当前页
  219. const handleNavigate = useCallback((page: NavigationPage) => {
  220. router.push(pathname + "?page=" + page);
  221. if (page !== "dashboard" && page !== "internal-chat") {
  222. selectConversation(null);
  223. }
  224. }, [pathname, router, selectConversation]);
  225. // 新建内部对话(知识库测试)- 必须在条件 return 之前声明,保证 Hooks 顺序一致
  226. const handleNewInternalConversation = useCallback(async () => {
  227. if (!agent?.id) return;
  228. try {
  229. const { conversation_id } = await initInternalConversation(agent.id);
  230. refreshConversations();
  231. selectConversation(conversation_id);
  232. } catch (e) {
  233. console.error("创建内部对话失败:", e);
  234. toast.error((e as Error).message || "创建内部对话失败");
  235. }
  236. }, [agent?.id, refreshConversations, selectConversation]);
  237. if (authLoading || (loading && isInitialLoad)) {
  238. return (
  239. <div className="flex justify-center items-center min-h-screen bg-background">
  240. <div className="text-lg text-muted-foreground">加载中...</div>
  241. </div>
  242. );
  243. }
  244. if (!agent) {
  245. return null;
  246. }
  247. const sidebarContent = isChatPage ? (
  248. <div className="flex h-full">
  249. <NavigationSidebar
  250. currentPage={currentPage}
  251. onNavigate={handleNavigate}
  252. onProfileClick={() => setProfileModalOpen(true)}
  253. onLogout={logout}
  254. avatarUrl={profile?.avatar_url}
  255. unreadChatCount={totalUnreadCount}
  256. />
  257. <ConversationSidebar
  258. conversations={filteredConversations}
  259. selectedConversationId={selectedConversationId}
  260. searchQuery={searchQuery}
  261. onSearchChange={setSearchQuery}
  262. onSelectConversation={handleConversationSelect}
  263. filter={conversationFilter}
  264. onFilterChange={setConversationFilter}
  265. status={conversationStatus}
  266. onStatusChange={(s) => {
  267. setConversationStatus(s);
  268. // 切换状态时清空搜索,更直观
  269. setSearchQuery("");
  270. }}
  271. mode={isInternalChat ? "internal" : "visitor"}
  272. onNewClick={isInternalChat ? handleNewInternalConversation : undefined}
  273. />
  274. </div>
  275. ) : (
  276. <div className="flex h-full">
  277. <NavigationSidebar
  278. currentPage={currentPage}
  279. onNavigate={handleNavigate}
  280. onProfileClick={() => setProfileModalOpen(true)}
  281. onLogout={logout}
  282. avatarUrl={profile?.avatar_url}
  283. unreadChatCount={totalUnreadCount}
  284. />
  285. </div>
  286. );
  287. const mainContent = (
  288. <div className="flex-1 flex flex-col bg-background min-h-0">
  289. {isChatPage ? (
  290. selectedConversationId ? (
  291. <>
  292. <ChatHeader
  293. conversationId={selectedConversationId}
  294. lastSeenAt={conversationDetail?.last_seen_at}
  295. unreadCount={selectedUnreadCount}
  296. onMarkAllRead={handleMarkAllRead}
  297. onCloseConversation={handleCloseConversation}
  298. onRefresh={handleRefreshChat}
  299. includeAIMessages={includeAIMessages}
  300. onToggleAIMessages={toggleAIMessages}
  301. soundEnabled={soundEnabled}
  302. onToggleSound={toggleSound}
  303. hideAIToggle={isInternalChat}
  304. />
  305. <MessageList
  306. messages={messages}
  307. loading={loadingMessages}
  308. highlightKeyword={highlightKeyword}
  309. onHighlightClear={clearHighlight}
  310. currentUserIsAgent={true}
  311. conversationId={selectedConversationId ?? null}
  312. onMarkMessagesRead={markMessagesAsRead}
  313. internalChatMode={isInternalChat}
  314. bottomSlot={
  315. isInternalChat && aiThinking ? (
  316. <div className="flex justify-start mt-2">
  317. <div className="inline-flex items-center gap-2 px-4 py-2 rounded-2xl rounded-bl-none bg-card border border-border/50 shadow-sm text-sm text-muted-foreground">
  318. <Loader2 className="w-4 h-4 animate-spin flex-shrink-0" />
  319. <span>AI 正在思考...</span>
  320. </div>
  321. </div>
  322. ) : null
  323. }
  324. />
  325. {/* 知识库测试:联网选项 */}
  326. {isInternalChat && (
  327. <div className="flex flex-wrap items-center gap-x-4 gap-y-2 px-2 py-2 border-t border-border/50 bg-muted/30 text-xs text-muted-foreground">
  328. <div className="flex items-center gap-2">
  329. <Checkbox
  330. id="internal-need-web-search"
  331. checked={needWebSearch}
  332. onCheckedChange={(v) => setNeedWebSearch(Boolean(v))}
  333. />
  334. <Label htmlFor="internal-need-web-search" className="cursor-pointer font-normal">
  335. 本回合联网搜索
  336. </Label>
  337. </div>
  338. </div>
  339. )}
  340. <MessageInput
  341. value={messageInput}
  342. onChange={setMessageInput}
  343. onSubmit={handleSendMessage}
  344. sending={sending}
  345. conversationId={selectedConversationId ?? undefined}
  346. />
  347. </>
  348. ) : (
  349. <div className="flex-1 flex items-center justify-center text-muted-foreground text-sm">
  350. {isInternalChat ? "选择或新建内部对话,测试知识库效果" : "选择一个对话开始聊天"}
  351. </div>
  352. )
  353. ) : (
  354. <div className="flex-1 flex flex-col min-h-0 overflow-hidden">
  355. {(() => {
  356. const PageComponent = currentPageMeta?.component;
  357. return PageComponent != null ? (
  358. <PageComponent embedded={true} />
  359. ) : null;
  360. })()}
  361. </div>
  362. )}
  363. </div>
  364. );
  365. const rightPanelContent = currentPage === "dashboard" && selectedConversationId ? (
  366. <VisitorDetailPanel
  367. conversation={selectedConversation}
  368. detail={conversationDetail}
  369. onRefresh={handleRefreshVisitor}
  370. onUpdateContact={updateContactInfo}
  371. />
  372. ) : undefined;
  373. return (
  374. <>
  375. <ResponsiveLayout
  376. sidebar={sidebarContent}
  377. main={mainContent}
  378. rightPanel={rightPanelContent}
  379. sidebarWidth={isChatPage ? LAYOUT.dashboardSidebarWidth : LAYOUT.navigationWidth}
  380. />
  381. {/* 个人资料弹窗 */}
  382. <ProfileModal
  383. profile={profile}
  384. open={profileModalOpen}
  385. onClose={() => setProfileModalOpen(false)}
  386. onUpdate={handleProfileUpdate}
  387. />
  388. </>
  389. );
  390. }