main.ts 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944
  1. // 使用 CommonJS 格式
  2. const { app, BrowserWindow, ipcMain, shell, session, Menu, Tray, nativeImage, webContents } = require('electron');
  3. const { join } = require('path');
  4. const fs = require('fs');
  5. const http = require('http');
  6. const https = require('https');
  7. let mainWindow: typeof BrowserWindow.prototype | null = null;
  8. let tray: typeof Tray.prototype | null = null;
  9. let isQuitting = false;
  10. const VITE_DEV_SERVER_URL = process.env.VITE_DEV_SERVER_URL;
  11. function setupCertificateBypass() {
  12. app.on('certificate-error', (event: Event, _webContents: typeof webContents.prototype, _url: string, _error: string, _certificate: unknown, callback: (isTrusted: boolean) => void) => {
  13. event.preventDefault();
  14. callback(true);
  15. });
  16. }
  17. function setupCorsBypassForApiRequests() {
  18. const ses = session.defaultSession;
  19. if (!ses) return;
  20. ses.webRequest.onHeadersReceived((details: { url: string; responseHeaders?: Record<string, string[] | string> }, callback: (response: { responseHeaders: Record<string, string[] | string> }) => void) => {
  21. const url = String(details.url || '');
  22. const isHttp = url.startsWith('http://') || url.startsWith('https://');
  23. const isApiLike = url.includes('/api/') || url.includes('/uploads/');
  24. if (!isHttp || !isApiLike) {
  25. callback({ responseHeaders: details.responseHeaders || {} });
  26. return;
  27. }
  28. const responseHeaders = { ...(details.responseHeaders || {}) };
  29. // 移除服务端已有的 CORS 头,避免与下面设置的值合并成 "origin1, *" 导致违规
  30. const corsKeys = ['access-control-allow-origin', 'Access-Control-Allow-Origin'];
  31. corsKeys.forEach((k) => delete responseHeaders[k]);
  32. responseHeaders['access-control-allow-origin'] = ['*'];
  33. responseHeaders['access-control-allow-methods'] = ['GET,POST,PUT,PATCH,DELETE,OPTIONS'];
  34. responseHeaders['access-control-allow-headers'] = ['Authorization,Content-Type,X-Requested-With'];
  35. responseHeaders['access-control-expose-headers'] = ['Content-Disposition,Content-Type'];
  36. callback({ responseHeaders });
  37. });
  38. }
  39. function normalizeBaseUrl(url: string): string {
  40. const raw = String(url || '').trim();
  41. if (!raw) return '';
  42. try {
  43. const u = new URL(raw);
  44. return `${u.protocol}//${u.host}`.replace(/\/$/, '');
  45. } catch {
  46. return raw.replace(/\/$/, '');
  47. }
  48. }
  49. function requestJson(url: string, timeoutMs: number): Promise<{ ok: boolean; status?: number; data?: any; error?: string }> {
  50. return new Promise((resolve) => {
  51. const u = new URL(url);
  52. const isHttps = u.protocol === 'https:';
  53. const lib = isHttps ? https : http;
  54. // Windows 上 localhost 常被解析为 ::1,而后端仅监听 127.0.0.1,导致 ECONNREFUSED
  55. const hostname = (u.hostname === 'localhost' || u.hostname === '::1') ? '127.0.0.1' : u.hostname;
  56. const req = lib.request({
  57. method: 'GET',
  58. protocol: u.protocol,
  59. hostname,
  60. port: u.port || (isHttps ? 443 : 80),
  61. path: `${u.pathname}${u.search}`,
  62. headers: {
  63. Accept: 'application/json',
  64. },
  65. timeout: timeoutMs,
  66. rejectUnauthorized: false,
  67. }, (res: any) => {
  68. const chunks: Buffer[] = [];
  69. res.on('data', (c: Buffer) => chunks.push(c));
  70. res.on('end', () => {
  71. const status = Number(res.statusCode || 0);
  72. const rawText = Buffer.concat(chunks).toString('utf-8');
  73. if (status < 200 || status >= 300) {
  74. resolve({ ok: false, status, error: `HTTP ${status}` });
  75. return;
  76. }
  77. try {
  78. const json = rawText ? JSON.parse(rawText) : null;
  79. resolve({ ok: true, status, data: json });
  80. } catch {
  81. resolve({ ok: false, status, error: '响应不是 JSON' });
  82. }
  83. });
  84. });
  85. req.on('timeout', () => {
  86. req.destroy(new Error('timeout'));
  87. });
  88. req.on('error', (err: any) => {
  89. resolve({ ok: false, error: err?.message || '网络错误' });
  90. });
  91. req.end();
  92. });
  93. }
  94. // 获取图标路径
  95. function getIconPath() {
  96. return VITE_DEV_SERVER_URL
  97. ? join(__dirname, '../public/icons/icon-256.png')
  98. : join(__dirname, '../dist/icons/icon-256.png');
  99. }
  100. // 获取托盘图标路径
  101. function getTrayIconPath() {
  102. return VITE_DEV_SERVER_URL
  103. ? join(__dirname, '../public/icons/tray-icon.png')
  104. : join(__dirname, '../dist/icons/tray-icon.png');
  105. }
  106. // 创建托盘图标
  107. function createTrayIcon(): typeof nativeImage.prototype {
  108. const trayIconPath = getTrayIconPath();
  109. return nativeImage.createFromPath(trayIconPath);
  110. }
  111. // 创建系统托盘
  112. function createTray() {
  113. const trayIcon = createTrayIcon();
  114. tray = new Tray(trayIcon);
  115. const contextMenu = Menu.buildFromTemplate([
  116. {
  117. label: '显示主窗口',
  118. click: () => {
  119. if (mainWindow) {
  120. mainWindow.show();
  121. mainWindow.focus();
  122. }
  123. }
  124. },
  125. {
  126. label: '最小化到托盘',
  127. click: () => {
  128. mainWindow?.hide();
  129. }
  130. },
  131. { type: 'separator' },
  132. {
  133. label: '退出',
  134. click: () => {
  135. isQuitting = true;
  136. app.quit();
  137. }
  138. }
  139. ]);
  140. tray.setToolTip('智媒通');
  141. tray.setContextMenu(contextMenu);
  142. // 点击托盘图标显示窗口
  143. tray.on('click', () => {
  144. if (mainWindow) {
  145. if (mainWindow.isVisible()) {
  146. mainWindow.focus();
  147. } else {
  148. mainWindow.show();
  149. mainWindow.focus();
  150. }
  151. }
  152. });
  153. // 双击托盘图标显示窗口
  154. tray.on('double-click', () => {
  155. if (mainWindow) {
  156. mainWindow.show();
  157. mainWindow.focus();
  158. }
  159. });
  160. }
  161. function createWindow() {
  162. // 隐藏默认菜单栏
  163. Menu.setApplicationMenu(null);
  164. const iconPath = getIconPath();
  165. mainWindow = new BrowserWindow({
  166. width: 1400,
  167. height: 900,
  168. minWidth: 1200,
  169. minHeight: 700,
  170. icon: iconPath,
  171. webPreferences: {
  172. preload: join(__dirname, 'preload.js'),
  173. nodeIntegration: false,
  174. contextIsolation: true,
  175. webviewTag: true, // 启用 webview 标签
  176. },
  177. frame: false, // 无边框窗口,自定义标题栏
  178. transparent: false,
  179. backgroundColor: '#f0f2f5',
  180. show: false,
  181. });
  182. // 窗口准备好后再显示,避免白屏
  183. mainWindow.once('ready-to-show', () => {
  184. mainWindow?.show();
  185. setupWindowEvents();
  186. });
  187. // 加载页面
  188. if (VITE_DEV_SERVER_URL) {
  189. mainWindow.loadURL(VITE_DEV_SERVER_URL);
  190. mainWindow.webContents.openDevTools();
  191. } else {
  192. mainWindow.loadFile(join(__dirname, '../dist/index.html'));
  193. }
  194. // 处理外部链接
  195. mainWindow.webContents.setWindowOpenHandler(({ url }: { url: string }) => {
  196. shell.openExternal(url);
  197. return { action: 'deny' };
  198. });
  199. // 关闭按钮默认最小化到托盘
  200. mainWindow.on('close', (event: Event) => {
  201. if (!isQuitting) {
  202. event.preventDefault();
  203. mainWindow?.hide();
  204. // 显示托盘通知(仅首次)
  205. if (tray && !app.isPackaged) {
  206. // 开发模式下可以显示通知
  207. }
  208. }
  209. });
  210. mainWindow.on('closed', () => {
  211. mainWindow = null;
  212. });
  213. }
  214. // 单实例锁定
  215. const gotTheLock = app.requestSingleInstanceLock();
  216. if (!gotTheLock) {
  217. app.quit();
  218. } else {
  219. app.on('second-instance', () => {
  220. if (mainWindow) {
  221. mainWindow.show();
  222. if (mainWindow.isMinimized()) mainWindow.restore();
  223. mainWindow.focus();
  224. }
  225. });
  226. app.whenReady().then(() => {
  227. createTray();
  228. createWindow();
  229. // 配置 webview session,允许第三方 cookies 和跨域请求
  230. setupWebviewSessions();
  231. setupCertificateBypass();
  232. setupCorsBypassForApiRequests();
  233. app.on('activate', () => {
  234. if (BrowserWindow.getAllWindows().length === 0) {
  235. createWindow();
  236. } else if (mainWindow) {
  237. mainWindow.show();
  238. }
  239. });
  240. });
  241. }
  242. // 配置 webview sessions
  243. function setupWebviewSessions() {
  244. // 监听新的 webContents 创建
  245. app.on('web-contents-created', (_event: unknown, contents: typeof webContents.prototype) => {
  246. // 为 webview 类型的 webContents 配置
  247. if (contents.getType() === 'webview') {
  248. // 设置 User-Agent(模拟 Chrome 浏览器)
  249. contents.setUserAgent(
  250. 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36'
  251. );
  252. // 拦截自定义协议链接(如 bitbrowser://)的导航
  253. contents.on('will-navigate', (event: Event, url: string) => {
  254. if (!isAllowedUrl(url)) {
  255. console.log('[WebView] 阻止导航到自定义协议:', url);
  256. event.preventDefault();
  257. }
  258. });
  259. // 拦截新窗口打开(包括自定义协议)
  260. contents.setWindowOpenHandler(({ url }: { url: string }) => {
  261. if (!isAllowedUrl(url)) {
  262. console.log('[WebView] 阻止打开自定义协议窗口:', url);
  263. return { action: 'deny' };
  264. }
  265. // 对于正常的 http/https 链接,在当前 webview 中打开
  266. console.log('[WebView] 拦截新窗口,在当前页面打开:', url);
  267. contents.loadURL(url);
  268. return { action: 'deny' };
  269. });
  270. // 允许所有的权限请求(如摄像头、地理位置等)
  271. contents.session.setPermissionRequestHandler((_webContents: unknown, permission: string, callback: (granted: boolean) => void) => {
  272. // 允许所有权限请求
  273. callback(true);
  274. });
  275. // 配置 webRequest 修改请求头,移除可能暴露 Electron 的特征
  276. contents.session.webRequest.onBeforeSendHeaders((details: { requestHeaders: Record<string, string> }, callback: (response: { requestHeaders: Record<string, string> }) => void) => {
  277. // 移除可能暴露 Electron 的请求头
  278. delete details.requestHeaders['X-DevTools-Emulate-Network-Conditions-Client-Id'];
  279. // 确保有正常的 Origin 和 Referer
  280. if (!details.requestHeaders['Origin'] && !details.requestHeaders['origin']) {
  281. // 不添加 Origin,让浏览器自动处理
  282. }
  283. callback({ requestHeaders: details.requestHeaders });
  284. });
  285. }
  286. });
  287. }
  288. // 检查 URL 是否是允许的协议
  289. function isAllowedUrl(url: string): boolean {
  290. if (!url) return false;
  291. const lowerUrl = url.toLowerCase();
  292. return lowerUrl.startsWith('http://') ||
  293. lowerUrl.startsWith('https://') ||
  294. lowerUrl.startsWith('about:') ||
  295. lowerUrl.startsWith('data:');
  296. }
  297. // 阻止默认的 window-all-closed 行为,保持托盘运行
  298. app.on('window-all-closed', () => {
  299. // 不退出应用,保持托盘运行
  300. // 只有在 isQuitting 为 true 时才真正退出
  301. });
  302. // 应用退出前清理托盘
  303. app.on('before-quit', () => {
  304. isQuitting = true;
  305. });
  306. app.on('quit', () => {
  307. if (tray) {
  308. tray.destroy();
  309. tray = null;
  310. }
  311. });
  312. ipcMain.handle('test-server-connection', async (_event: unknown, args: { url: string }) => {
  313. try {
  314. const baseUrl = normalizeBaseUrl(args?.url);
  315. if (!baseUrl) return { ok: false, error: '未填写服务器地址' };
  316. const result = await requestJson(`${baseUrl}/api/health`, 5000);
  317. if (!result.ok) return { ok: false, error: result.error || '连接失败' };
  318. if (result.data?.status === 'ok') return { ok: true };
  319. return { ok: false, error: '服务器响应异常' };
  320. } catch (e: any) {
  321. return { ok: false, error: e?.message || '连接失败' };
  322. }
  323. });
  324. // Python 服务测试连接(主进程发起,支持 HTTP/HTTPS,无跨域限制)
  325. ipcMain.handle('test-python-service-connection', async (_event: unknown, args: { url: string }) => {
  326. try {
  327. const baseUrl = normalizeBaseUrl(args?.url);
  328. if (!baseUrl) return { ok: false, error: '未填写 Python 服务地址' };
  329. const result = await requestJson(`${baseUrl}/health`, 5000);
  330. if (!result.ok) return { ok: false, error: result.error || '连接失败' };
  331. return { ok: true };
  332. } catch (e: any) {
  333. return { ok: false, error: e?.message || '连接失败' };
  334. }
  335. });
  336. // IPC 处理
  337. ipcMain.handle('get-app-version', () => {
  338. return app.getVersion();
  339. });
  340. ipcMain.handle('get-platform', () => {
  341. return process.platform;
  342. });
  343. // 窗口控制
  344. ipcMain.on('window-minimize', () => {
  345. mainWindow?.minimize();
  346. });
  347. ipcMain.on('window-maximize', () => {
  348. if (mainWindow?.isMaximized()) {
  349. mainWindow.unmaximize();
  350. } else {
  351. mainWindow?.maximize();
  352. }
  353. });
  354. // 关闭窗口(最小化到托盘)
  355. ipcMain.on('window-close', () => {
  356. mainWindow?.hide();
  357. });
  358. // 真正退出应用
  359. ipcMain.on('app-quit', () => {
  360. isQuitting = true;
  361. app.quit();
  362. });
  363. // 获取窗口最大化状态
  364. ipcMain.handle('window-is-maximized', () => {
  365. return mainWindow?.isMaximized() || false;
  366. });
  367. // 监听窗口最大化/还原事件,通知渲染进程
  368. function setupWindowEvents() {
  369. mainWindow?.on('maximize', () => {
  370. mainWindow?.webContents.send('window-maximized', true);
  371. });
  372. mainWindow?.on('unmaximize', () => {
  373. mainWindow?.webContents.send('window-maximized', false);
  374. });
  375. }
  376. // 弹窗打开平台后台(独立窗口,不嵌入;用于实验,可回归为嵌入)
  377. ipcMain.handle('open-backend-external', async (_event: unknown, payload: { url: string; cookieData?: string; title?: string }) => {
  378. const { url, cookieData, title } = payload || {};
  379. if (!url || typeof url !== 'string') return;
  380. const partition = 'persist:backend-popup-' + Date.now();
  381. const ses = session.fromPartition(partition);
  382. if (cookieData && typeof cookieData === 'string' && cookieData.trim()) {
  383. const raw = cookieData.trim();
  384. let cookiesToSet: Array<{ name: string; value: string; domain?: string; path?: string }> = [];
  385. try {
  386. if (raw.startsWith('[') || raw.startsWith('{')) {
  387. const parsed = JSON.parse(raw);
  388. const arr = Array.isArray(parsed) ? parsed : (parsed?.cookies || []);
  389. cookiesToSet = arr.map((c: { name?: string; value?: string; domain?: string; path?: string }) => ({
  390. name: String(c?.name ?? '').trim(),
  391. value: String(c?.value ?? '').trim(),
  392. domain: c?.domain ? String(c.domain) : undefined,
  393. path: c?.path ? String(c.path) : '/',
  394. })).filter((c: { name: string }) => c.name);
  395. } else {
  396. raw.split(';').forEach((p: string) => {
  397. const idx = p.indexOf('=');
  398. if (idx > 0) {
  399. const name = p.slice(0, idx).trim();
  400. const value = p.slice(idx + 1).trim();
  401. if (name) cookiesToSet.push({ name, value, path: '/' });
  402. }
  403. });
  404. }
  405. } catch (e) {
  406. console.warn('[open-backend-external] 解析 cookie 失败', e);
  407. }
  408. const origin = new URL(url).origin;
  409. const hostname = new URL(url).hostname;
  410. const defaultDomain = hostname.startsWith('www.') ? hostname.slice(4) : hostname;
  411. const domainWithDot = defaultDomain.includes('.') ? '.' + defaultDomain.split('.').slice(-2).join('.') : undefined;
  412. for (const c of cookiesToSet) {
  413. try {
  414. await ses.cookies.set({
  415. url: origin + '/',
  416. name: c.name,
  417. value: c.value,
  418. domain: c.domain || domainWithDot || hostname,
  419. path: c.path || '/',
  420. });
  421. } catch (err) {
  422. console.warn('[open-backend-external] 设置 cookie 失败', c.name, err);
  423. }
  424. }
  425. }
  426. const win = new BrowserWindow({
  427. width: 1280,
  428. height: 800,
  429. title: title || '平台后台',
  430. icon: getIconPath(),
  431. webPreferences: {
  432. session: ses,
  433. nodeIntegration: false,
  434. contextIsolation: true,
  435. },
  436. show: false,
  437. });
  438. win.once('ready-to-show', () => {
  439. win.show();
  440. });
  441. await win.loadURL(url);
  442. return { ok: true };
  443. });
  444. // 获取 webview 的 cookies
  445. ipcMain.handle('get-webview-cookies', async (_event: unknown, partition: string, url: string) => {
  446. try {
  447. const ses = session.fromPartition(partition);
  448. const cookies = await ses.cookies.get({ url });
  449. return cookies;
  450. } catch (error) {
  451. console.error('获取 cookies 失败:', error);
  452. return [];
  453. }
  454. });
  455. // 清除 webview 的 cookies
  456. ipcMain.handle('clear-webview-cookies', async (_event: unknown, partition: string) => {
  457. try {
  458. const ses = session.fromPartition(partition);
  459. await ses.clearStorageData({ storages: ['cookies'] });
  460. return true;
  461. } catch (error) {
  462. console.error('清除 cookies 失败:', error);
  463. return false;
  464. }
  465. });
  466. // 设置 webview 的 cookies
  467. ipcMain.handle('set-webview-cookies', async (_event: unknown, partition: string, cookies: Electron.CookiesSetDetails[]) => {
  468. try {
  469. console.log(`[Main] 设置 webview cookies, partition=${partition}, count=${cookies.length}`);
  470. const ses = session.fromPartition(partition);
  471. // 逐个设置 cookie
  472. let successCount = 0;
  473. for (const cookie of cookies) {
  474. try {
  475. // 确保 Cookie 格式正确
  476. const cookieToSet: Electron.CookiesSetDetails = {
  477. url: cookie.url,
  478. name: cookie.name,
  479. value: cookie.value,
  480. domain: cookie.domain,
  481. path: cookie.path || '/',
  482. };
  483. // 可选字段
  484. if (cookie.expirationDate) {
  485. cookieToSet.expirationDate = cookie.expirationDate;
  486. }
  487. if (cookie.httpOnly !== undefined) {
  488. cookieToSet.httpOnly = cookie.httpOnly;
  489. }
  490. if (cookie.secure !== undefined) {
  491. cookieToSet.secure = cookie.secure;
  492. }
  493. if (cookie.sameSite) {
  494. cookieToSet.sameSite = cookie.sameSite as 'no_restriction' | 'lax' | 'strict';
  495. }
  496. await ses.cookies.set(cookieToSet);
  497. successCount++;
  498. // 记录关键 Cookie
  499. if (cookie.name === 'BDUSS' || cookie.name === 'STOKEN' || cookie.name === 'sessionid') {
  500. console.log(`[Main] 成功设置关键 Cookie: ${cookie.name}, domain: ${cookie.domain}`);
  501. }
  502. } catch (error) {
  503. console.error(`[Main] 设置 cookie 失败 (${cookie.name}):`, error);
  504. }
  505. }
  506. console.log(`[Main] 成功设置 ${successCount}/${cookies.length} 个 cookies`);
  507. // 验证 Cookie 是否真的设置成功
  508. try {
  509. const setCookies = await ses.cookies.get({ domain: '.baidu.com' });
  510. console.log(`[Main] 验证:当前 session 中有 ${setCookies.length} 个百度 Cookie`);
  511. const keyNames = setCookies.slice(0, 5).map(c => c.name).join(', ');
  512. console.log(`[Main] 关键 Cookie 名称: ${keyNames}`);
  513. } catch (verifyError) {
  514. console.error('[Main] 验证 Cookie 失败:', verifyError);
  515. }
  516. return true;
  517. } catch (error) {
  518. console.error('[Main] 设置 cookies 失败:', error);
  519. return false;
  520. }
  521. });
  522. // 截取 webview 页面截图(用于 AI 分析)
  523. ipcMain.handle('capture-webview-page', async (_event: unknown, webContentsId: number) => {
  524. try {
  525. const wc = webContents.fromId(webContentsId);
  526. if (!wc) {
  527. console.error('找不到 webContents:', webContentsId);
  528. return null;
  529. }
  530. const image = await wc.capturePage();
  531. if (!image || image.isEmpty()) {
  532. console.warn('截图为空');
  533. return null;
  534. }
  535. // 转换为 JPEG 格式的 Base64
  536. const buffer = image.toJPEG(80);
  537. return buffer.toString('base64');
  538. } catch (error) {
  539. console.error('截图失败:', error);
  540. return null;
  541. }
  542. });
  543. // 向 webview 发送鼠标点击事件
  544. ipcMain.handle('webview-send-mouse-click', async (_event: unknown, webContentsId: number, x: number, y: number) => {
  545. try {
  546. const wc = webContents.fromId(webContentsId);
  547. if (!wc) {
  548. console.error('找不到 webContents:', webContentsId);
  549. return false;
  550. }
  551. // 发送鼠标移动事件
  552. wc.sendInputEvent({
  553. type: 'mouseMove',
  554. x: Math.round(x),
  555. y: Math.round(y),
  556. });
  557. // 短暂延迟后发送点击事件
  558. await new Promise(resolve => setTimeout(resolve, 50));
  559. // 发送鼠标按下事件
  560. wc.sendInputEvent({
  561. type: 'mouseDown',
  562. x: Math.round(x),
  563. y: Math.round(y),
  564. button: 'left',
  565. clickCount: 1,
  566. });
  567. // 短暂延迟后发送鼠标抬起事件
  568. await new Promise(resolve => setTimeout(resolve, 50));
  569. wc.sendInputEvent({
  570. type: 'mouseUp',
  571. x: Math.round(x),
  572. y: Math.round(y),
  573. button: 'left',
  574. clickCount: 1,
  575. });
  576. console.log(`[webview-send-mouse-click] Clicked at (${x}, ${y})`);
  577. return true;
  578. } catch (error) {
  579. console.error('发送点击事件失败:', error);
  580. return false;
  581. }
  582. });
  583. // 向 webview 发送键盘输入事件
  584. ipcMain.handle('webview-send-text-input', async (_event: unknown, webContentsId: number, text: string) => {
  585. try {
  586. const wc = webContents.fromId(webContentsId);
  587. if (!wc) {
  588. console.error('找不到 webContents:', webContentsId);
  589. return false;
  590. }
  591. // 逐字符输入
  592. for (const char of text) {
  593. wc.sendInputEvent({
  594. type: 'char',
  595. keyCode: char,
  596. });
  597. await new Promise(resolve => setTimeout(resolve, 30));
  598. }
  599. console.log(`[webview-send-text-input] Typed: ${text}`);
  600. return true;
  601. } catch (error) {
  602. console.error('发送输入事件失败:', error);
  603. return false;
  604. }
  605. });
  606. // 获取 webview 页面元素位置
  607. ipcMain.handle('webview-get-element-position', async (_event: unknown, webContentsId: number, selector: string) => {
  608. try {
  609. const wc = webContents.fromId(webContentsId);
  610. if (!wc) {
  611. console.error('找不到 webContents:', webContentsId);
  612. return null;
  613. }
  614. const result = await wc.executeJavaScript(`
  615. (function() {
  616. const el = document.querySelector('${selector.replace(/'/g, "\\'")}');
  617. if (!el) return null;
  618. const rect = el.getBoundingClientRect();
  619. return {
  620. x: rect.left + rect.width / 2,
  621. y: rect.top + rect.height / 2,
  622. width: rect.width,
  623. height: rect.height
  624. };
  625. })()
  626. `);
  627. return result;
  628. } catch (error) {
  629. console.error('获取元素位置失败:', error);
  630. return null;
  631. }
  632. });
  633. // 通过文本内容查找并点击元素
  634. ipcMain.handle('webview-click-by-text', async (_event: unknown, webContentsId: number, text: string) => {
  635. try {
  636. const wc = webContents.fromId(webContentsId);
  637. if (!wc) {
  638. console.error('找不到 webContents:', webContentsId);
  639. return false;
  640. }
  641. // 查找包含指定文本的可点击元素的位置
  642. const position = await wc.executeJavaScript(`
  643. (function() {
  644. const searchText = '${text.replace(/'/g, "\\'")}';
  645. // 查找可点击元素
  646. const clickables = document.querySelectorAll('a, button, [role="button"], [onclick], input[type="submit"], input[type="button"]');
  647. for (const el of clickables) {
  648. if (el.textContent?.includes(searchText) || el.getAttribute('aria-label')?.includes(searchText) || el.getAttribute('title')?.includes(searchText)) {
  649. const rect = el.getBoundingClientRect();
  650. if (rect.width > 0 && rect.height > 0) {
  651. return { x: rect.left + rect.width / 2, y: rect.top + rect.height / 2 };
  652. }
  653. }
  654. }
  655. // 查找所有包含文本的元素
  656. const allElements = document.querySelectorAll('*');
  657. for (const el of allElements) {
  658. const text = el.innerText?.trim();
  659. if (text && text.length < 100 && text.includes(searchText)) {
  660. const rect = el.getBoundingClientRect();
  661. if (rect.width > 0 && rect.height > 0 && rect.width < 500) {
  662. return { x: rect.left + rect.width / 2, y: rect.top + rect.height / 2 };
  663. }
  664. }
  665. }
  666. return null;
  667. })()
  668. `);
  669. if (!position) {
  670. console.warn(`[webview-click-by-text] 未找到包含 "${text}" 的元素`);
  671. return false;
  672. }
  673. // 发送点击事件
  674. wc.sendInputEvent({ type: 'mouseMove', x: Math.round(position.x), y: Math.round(position.y) });
  675. await new Promise(resolve => setTimeout(resolve, 50));
  676. wc.sendInputEvent({ type: 'mouseDown', x: Math.round(position.x), y: Math.round(position.y), button: 'left', clickCount: 1 });
  677. await new Promise(resolve => setTimeout(resolve, 50));
  678. wc.sendInputEvent({ type: 'mouseUp', x: Math.round(position.x), y: Math.round(position.y), button: 'left', clickCount: 1 });
  679. console.log(`[webview-click-by-text] Clicked "${text}" at (${position.x}, ${position.y})`);
  680. return true;
  681. } catch (error) {
  682. console.error('通过文本点击失败:', error);
  683. return false;
  684. }
  685. });
  686. // ========== CDP 网络拦截功能 ==========
  687. // 存储每个 webContents 的网络拦截配置
  688. const networkInterceptors: Map<number, {
  689. patterns: Array<{ match: string, key: string }>;
  690. pendingRequests: Map<string, { url: string, timestamp: number }>;
  691. }> = new Map();
  692. // 启用 CDP 网络拦截
  693. ipcMain.handle('enable-network-intercept', async (_event: unknown, webContentsId: number, patterns: Array<{ match: string, key: string }>) => {
  694. try {
  695. const wc = webContents.fromId(webContentsId);
  696. if (!wc) {
  697. console.error('[CDP] 找不到 webContents:', webContentsId);
  698. return false;
  699. }
  700. // 如果已经有拦截器,先清理
  701. if (networkInterceptors.has(webContentsId)) {
  702. try {
  703. wc.debugger.detach();
  704. } catch (e) {
  705. // 忽略
  706. }
  707. }
  708. // 存储配置
  709. networkInterceptors.set(webContentsId, {
  710. patterns,
  711. pendingRequests: new Map()
  712. });
  713. // 附加调试器
  714. try {
  715. wc.debugger.attach('1.3');
  716. } catch (err: unknown) {
  717. const error = err as Error;
  718. if (!error.message?.includes('Already attached')) {
  719. throw err;
  720. }
  721. }
  722. // 启用网络监听
  723. await wc.debugger.sendCommand('Network.enable');
  724. // 监听网络响应
  725. wc.debugger.on('message', async (_e: unknown, method: string, params: {
  726. requestId?: string;
  727. response?: { url?: string; status?: number; mimeType?: string };
  728. encodedDataLength?: number;
  729. }) => {
  730. const config = networkInterceptors.get(webContentsId);
  731. if (!config) return;
  732. if (method === 'Network.responseReceived') {
  733. const { requestId, response } = params;
  734. if (!requestId || !response?.url) return;
  735. // 调试:打印百家号相关的所有 API 请求
  736. if (response.url.includes('baijiahao.baidu.com')) {
  737. if (response.url.includes('/pcui/') || response.url.includes('/article')) {
  738. console.log(`[CDP DEBUG] 百家号 API: ${response.url}`);
  739. }
  740. }
  741. // 检查是否匹配我们关注的 API
  742. for (const pattern of config.patterns) {
  743. if (response.url.includes(pattern.match)) {
  744. // 记录请求,等待响应完成
  745. config.pendingRequests.set(requestId, {
  746. url: response.url,
  747. timestamp: Date.now()
  748. });
  749. console.log(`[CDP] 匹配到 API: ${pattern.key} - ${response.url}`);
  750. break;
  751. }
  752. }
  753. }
  754. if (method === 'Network.loadingFinished') {
  755. const { requestId } = params;
  756. if (!requestId) return;
  757. const pending = config.pendingRequests.get(requestId);
  758. if (!pending) return;
  759. config.pendingRequests.delete(requestId);
  760. try {
  761. // 获取响应体
  762. const result = await wc.debugger.sendCommand('Network.getResponseBody', { requestId }) as { body: string; base64Encoded: boolean };
  763. let body = result.body;
  764. // 如果是 base64 编码,解码
  765. if (result.base64Encoded) {
  766. body = Buffer.from(body, 'base64').toString('utf8');
  767. }
  768. // 解析 JSON
  769. const data = JSON.parse(body);
  770. // 找到匹配的 key
  771. let matchedKey = '';
  772. for (const pattern of config.patterns) {
  773. if (pending.url.includes(pattern.match)) {
  774. matchedKey = pattern.key;
  775. break;
  776. }
  777. }
  778. if (matchedKey) {
  779. console.log(`[CDP] 获取到响应: ${matchedKey}`, JSON.stringify(data).substring(0, 200));
  780. // 发送到渲染进程
  781. mainWindow?.webContents.send('network-intercept-data', {
  782. webContentsId,
  783. key: matchedKey,
  784. url: pending.url,
  785. data
  786. });
  787. }
  788. } catch (err) {
  789. console.warn(`[CDP] 获取响应体失败:`, err);
  790. }
  791. }
  792. });
  793. console.log(`[CDP] 已启用网络拦截,webContentsId: ${webContentsId}, patterns:`, patterns.map(p => p.key));
  794. return true;
  795. } catch (error) {
  796. console.error('[CDP] 启用网络拦截失败:', error);
  797. return false;
  798. }
  799. });
  800. // 禁用 CDP 网络拦截
  801. ipcMain.handle('disable-network-intercept', async (_event: unknown, webContentsId: number) => {
  802. try {
  803. const wc = webContents.fromId(webContentsId);
  804. if (wc) {
  805. try {
  806. wc.debugger.detach();
  807. } catch (e) {
  808. // 忽略
  809. }
  810. }
  811. networkInterceptors.delete(webContentsId);
  812. console.log(`[CDP] 已禁用网络拦截,webContentsId: ${webContentsId}`);
  813. return true;
  814. } catch (error) {
  815. console.error('[CDP] 禁用网络拦截失败:', error);
  816. return false;
  817. }
  818. });
  819. // 更新网络拦截的 patterns
  820. ipcMain.handle('update-network-patterns', async (_event: unknown, webContentsId: number, patterns: Array<{ match: string, key: string }>) => {
  821. const config = networkInterceptors.get(webContentsId);
  822. if (config) {
  823. config.patterns = patterns;
  824. console.log(`[CDP] 已更新 patterns,webContentsId: ${webContentsId}`);
  825. return true;
  826. }
  827. return false;
  828. });