app.js 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988
  1. // 全局变量
  2. let cy = null;
  3. let currentTaskId = null;
  4. let currentTopologyId = null;
  5. let currentTerminal = null; // 当前终端实例
  6. // 初始化
  7. document.addEventListener('DOMContentLoaded', function() {
  8. initCytoscape();
  9. initEventListeners();
  10. loadTopologyList(); // 加载拓扑列表
  11. loadTopology();
  12. loadDeviceList(); // 加载设备列表
  13. });
  14. // 初始化Cytoscape
  15. function initCytoscape() {
  16. cy = cytoscape({
  17. container: document.getElementById('cy'),
  18. elements: [],
  19. style: [
  20. {
  21. selector: 'node',
  22. style: {
  23. 'label': 'data(label)',
  24. 'background-color': function(ele) {
  25. return getNodeColor(ele.data('type'));
  26. },
  27. 'width': 70,
  28. 'height': 70,
  29. 'border-width': 3,
  30. 'border-color': '#667eea',
  31. 'text-valign': 'bottom',
  32. 'text-halign': 'center',
  33. 'font-size': '11px',
  34. 'font-weight': 'bold',
  35. 'text-wrap': 'wrap',
  36. 'text-max-width': '80px'
  37. }
  38. },
  39. {
  40. selector: 'edge',
  41. style: {
  42. 'width': 2,
  43. 'line-color': '#999',
  44. 'curve-style': 'bezier',
  45. 'label': 'data(protocol)'
  46. }
  47. },
  48. {
  49. selector: 'node:selected',
  50. style: {
  51. 'border-width': 5,
  52. 'border-color': '#FF9800'
  53. }
  54. }
  55. ],
  56. layout: {
  57. name: 'cose',
  58. animate: true,
  59. animationDuration: 1000,
  60. padding: 30
  61. }
  62. });
  63. // 节点点击事件
  64. cy.on('tap', 'node', function(evt) {
  65. const node = evt.target;
  66. showDeviceDetail(node.data('id'));
  67. });
  68. }
  69. // 获取节点颜色
  70. function getNodeColor(type) {
  71. const colors = {
  72. 'cisco': '#4CAF50',
  73. 'huawei': '#2196F3',
  74. 'h3c': '#9C27B0',
  75. 'asa': '#FF5722',
  76. 'linux': '#607D8B',
  77. 'windows': '#00BCD4'
  78. };
  79. return colors[type] || '#999';
  80. }
  81. // 初始化事件监听
  82. function initEventListeners() {
  83. // 拓扑选择器
  84. document.getElementById('topology-selector').addEventListener('change', switchTopology);
  85. // 新建拓扑按钮
  86. document.getElementById('btn-new-topology').addEventListener('click', function() {
  87. document.getElementById('modal-new-topology').classList.add('active');
  88. });
  89. // 关闭新建拓扑模态框
  90. document.querySelector('.close-new-topology').addEventListener('click', function() {
  91. document.getElementById('modal-new-topology').classList.remove('active');
  92. });
  93. // 关闭编辑设备模态框
  94. document.querySelector('.close-edit-device').addEventListener('click', function() {
  95. document.getElementById('modal-edit-device').classList.remove('active');
  96. });
  97. // 新建拓扑表单
  98. document.getElementById('new-topology-form').addEventListener('submit', createTopology);
  99. // 扫描按钮
  100. document.getElementById('btn-scan').addEventListener('click', startScan);
  101. // 添加设备按钮
  102. document.getElementById('btn-add-device').addEventListener('click', function() {
  103. document.getElementById('modal').classList.add('active');
  104. });
  105. // 关闭模态框
  106. document.querySelector('.close').addEventListener('click', function() {
  107. document.getElementById('modal').classList.remove('active');
  108. });
  109. // 添加设备表单
  110. document.getElementById('add-device-form').addEventListener('submit', addDevice);
  111. // 导出按钮
  112. document.getElementById('btn-export').addEventListener('click', exportTopology);
  113. // 登出按钮
  114. var logoutBtn = document.getElementById('btn-logout');
  115. if (logoutBtn) {
  116. logoutBtn.addEventListener('click', function() {
  117. window.location.href = '/api/logout';
  118. });
  119. }
  120. // SSH终端相关
  121. document.querySelector('.close-terminal').addEventListener('click', closeTerminal);
  122. // 终端模态框拖动功能
  123. (function() {
  124. var dragHandle = document.querySelector('.modal-header-drag');
  125. var modal = document.querySelector('.terminal-modal-content');
  126. var isDragging = false;
  127. var offsetX = 0, offsetY = 0;
  128. if (dragHandle && modal) {
  129. dragHandle.addEventListener('mousedown', function(e) {
  130. if (e.target.classList.contains('close-terminal')) return;
  131. isDragging = true;
  132. var rect = modal.getBoundingClientRect();
  133. offsetX = e.clientX - rect.left;
  134. offsetY = e.clientY - rect.top;
  135. modal.style.margin = '0';
  136. modal.style.position = 'absolute';
  137. modal.style.left = rect.left + 'px';
  138. modal.style.top = rect.top + 'px';
  139. e.preventDefault();
  140. });
  141. document.addEventListener('mousemove', function(e) {
  142. if (!isDragging) return;
  143. modal.style.left = (e.clientX - offsetX) + 'px';
  144. modal.style.top = (e.clientY - offsetY) + 'px';
  145. });
  146. document.addEventListener('mouseup', function() {
  147. isDragging = false;
  148. });
  149. }
  150. })();
  151. document.querySelector('.close-ssh-creds').addEventListener('click', function() {
  152. document.getElementById('modal-ssh-creds').classList.remove('active');
  153. });
  154. document.getElementById('ssh-creds-form').addEventListener('submit', connectTerminal);
  155. // 设备选择器相关
  156. document.querySelector('.close-select-devices').addEventListener('click', function() {
  157. document.getElementById('modal-select-devices').classList.remove('active');
  158. });
  159. }
  160. // 开始扫描
  161. async function startScan() {
  162. const scanRange = document.getElementById('scan-range').value;
  163. const sshPort = document.getElementById('ssh-port').value;
  164. const username = document.getElementById('username').value;
  165. const password = document.getElementById('password').value;
  166. if (!scanRange) {
  167. alert('请输入IP范围');
  168. return;
  169. }
  170. try {
  171. const response = await fetch('/api/scan', {
  172. method: 'POST',
  173. headers: {
  174. 'Content-Type': 'application/json'
  175. },
  176. body: JSON.stringify({
  177. scan_range: scanRange,
  178. ssh_port: parseInt(sshPort),
  179. username: username,
  180. password: password
  181. })
  182. });
  183. const data = await response.json();
  184. currentTaskId = data.task_id;
  185. // 轮询进度
  186. pollProgress();
  187. } catch (error) {
  188. console.error('扫描失败:', error);
  189. alert('扫描失败: ' + error.message);
  190. }
  191. }
  192. // 轮询进度
  193. async function pollProgress() {
  194. if (!currentTaskId) return;
  195. let failCount = 0;
  196. const MAX_FAILS = 5;
  197. const poll = async () => {
  198. try {
  199. const response = await fetch(`/api/scan/${currentTaskId}`);
  200. if (!response.ok) {
  201. throw new Error(`HTTP ${response.status}`);
  202. }
  203. const task = await response.json();
  204. failCount = 0; // 重置失败计数
  205. // 更新进度
  206. document.getElementById('scan-status').textContent = task.status;
  207. document.getElementById('scan-progress').textContent = task.progress + '%';
  208. document.getElementById('progress-fill').style.width = task.progress + '%';
  209. // 更新设备列表(仅当有设备时)
  210. if (task.devices && task.devices.length > 0) {
  211. updateDeviceList(task.devices);
  212. }
  213. // 如果完成,更新拓扑
  214. if (task.status === 'completed' || task.status === 'failed') {
  215. loadTopology();
  216. loadDeviceList(); // 刷新设备列表
  217. currentTaskId = null;
  218. return;
  219. }
  220. // 继续轮询
  221. setTimeout(poll, 1000);
  222. } catch (error) {
  223. failCount++;
  224. console.error('获取进度失败:', error);
  225. // 超过最大失败次数则停止轮询
  226. if (failCount >= MAX_FAILS) {
  227. document.getElementById('scan-status').textContent = 'error';
  228. currentTaskId = null;
  229. return;
  230. }
  231. // 等待更长时间后重试
  232. setTimeout(poll, 2000);
  233. }
  234. };
  235. poll();
  236. }
  237. // 更新设备列表
  238. function updateDeviceList(devices) {
  239. const listContainer = document.getElementById('device-list');
  240. listContainer.innerHTML = '';
  241. devices.forEach(device => {
  242. const item = document.createElement('div');
  243. item.className = 'device-item';
  244. item.innerHTML = `
  245. <div class="ip">${device.ip}</div>
  246. <div class="type">${device.type} - ${device.hostname || 'Unknown'}</div>
  247. <div class="status status-${device.scan_status.replace(' ', '-')}">${device.scan_status}</div>
  248. `;
  249. item.addEventListener('click', () => showDeviceDetail(device.id));
  250. listContainer.appendChild(item);
  251. });
  252. }
  253. // 加载拓扑
  254. async function loadTopology() {
  255. try {
  256. const response = await fetch('/api/topology');
  257. const graph = await response.json();
  258. // 清空现有元素
  259. cy.elements().remove();
  260. // 添加节点
  261. graph.nodes.forEach(node => {
  262. // 显示格式: 主机名 + IP地址
  263. let label = node.ip; // 默认显示IP
  264. if (node.hostname && node.hostname !== '') {
  265. label = `${node.hostname}\n${node.ip}`;
  266. }
  267. cy.add({
  268. group: 'nodes',
  269. data: {
  270. id: node.id,
  271. label: label,
  272. type: node.type,
  273. ip: node.ip,
  274. hostname: node.hostname
  275. }
  276. });
  277. });
  278. // 添加边
  279. graph.edges.forEach(edge => {
  280. cy.add({
  281. group: 'edges',
  282. data: {
  283. id: edge.id,
  284. source: edge.source,
  285. target: edge.target,
  286. protocol: edge.protocol
  287. }
  288. });
  289. });
  290. // 重新布局
  291. cy.layout({
  292. name: 'cose',
  293. animate: true,
  294. animationDuration: 1000,
  295. padding: 30
  296. }).run();
  297. cy.fit(40);
  298. } catch (error) {
  299. console.error('加载拓扑失败:', error);
  300. }
  301. }
  302. // 加载设备列表
  303. async function loadDeviceList() {
  304. try {
  305. const response = await fetch('/api/devices');
  306. const devices = await response.json();
  307. const listContainer = document.getElementById('device-list');
  308. listContainer.innerHTML = '';
  309. if (devices.length === 0) {
  310. listContainer.innerHTML = '<p style="color: #999; text-align: center;">暂无设备</p>';
  311. return;
  312. }
  313. devices.forEach(device => {
  314. const item = document.createElement('div');
  315. item.className = 'device-item';
  316. const interfaceCount = device.interfaces ? device.interfaces.length : 0;
  317. const neighborCount = device.neighbors ? device.neighbors.length : 0;
  318. item.innerHTML = `
  319. <div class="ip">${device.ip}</div>
  320. <div class="type">${device.type} - ${device.hostname || 'Unknown'}</div>
  321. <div class="info" style="font-size: 11px; color: #999; margin-top: 5px;">
  322. 接口: ${interfaceCount} | 邻居: ${neighborCount}
  323. </div>
  324. <div class="status status-${(device.scan_status || 'pending').replace(' ', '-')}">${device.scan_status || 'pending'}</div>
  325. `;
  326. item.addEventListener('click', () => showDeviceDetail(device.id || device.ip));
  327. listContainer.appendChild(item);
  328. });
  329. } catch (error) {
  330. console.error('加载设备列表失败:', error);
  331. }
  332. }
  333. // 显示设备详情
  334. async function showDeviceDetail(deviceId) {
  335. try {
  336. const response = await fetch(`/api/device/${deviceId}`);
  337. if (response.status === 401) {
  338. window.location.href = '/login';
  339. return;
  340. }
  341. if (!response.ok) {
  342. console.error('获取设备详情失败:', response.status, response.statusText);
  343. return;
  344. }
  345. const device = await response.json();
  346. const detailPanel = document.getElementById('detail-panel');
  347. const detailContainer = document.getElementById('device-detail');
  348. detailContainer.innerHTML = `
  349. <div class="detail-section">
  350. <h4>基本信息</h4>
  351. <p><strong>IP:</strong> ${device.ip}</p>
  352. <p><strong>主机名:</strong> ${device.hostname || 'N/A'}</p>
  353. <p><strong>类型:</strong> ${device.type}</p>
  354. <p><strong>系统:</strong> ${device.os_version || 'N/A'}</p>
  355. <p><strong>运行时间:</strong> ${device.uptime || 'N/A'}</p>
  356. <div style="display:flex;gap:10px;margin-top:10px">
  357. <button class="btn btn-primary" style="flex:1" onclick="openSSHTerminal('${device.ip}', '${device.hostname || device.ip}')">SSH 连接</button>
  358. <button class="btn btn-secondary" style="flex:1" onclick="openEditDevice('${device.id}', '${device.hostname}', '${device.type}')">编辑</button>
  359. <button class="btn btn-danger" style="flex:1" onclick="deleteDevice('${device.id}')">删除</button>
  360. </div>
  361. </div>
  362. <div class="detail-section">
  363. <h4>接口信息 (${device.interfaces.length})</h4>
  364. ${device.interfaces.map(iface => `
  365. <div class="interface-item">
  366. <div class="name">${iface.name}</div>
  367. <div class="info">
  368. <p>状态: <span class="status-${iface.status.replace(' ', '-')}">${iface.status}</span></p>
  369. <p>IP: ${iface.ip || 'N/A'}</p>
  370. <p>MAC: ${iface.mac || 'N/A'}</p>
  371. <p>速度: ${iface.speed || 'N/A'}</p>
  372. <p>双工: ${iface.duplex || 'N/A'}</p>
  373. <p>VLAN: ${iface.vlan || 'N/A'}</p>
  374. </div>
  375. </div>
  376. `).join('')}
  377. </div>
  378. <div class="detail-section">
  379. <h4>邻居设备 (${device.neighbors.length})</h4>
  380. ${device.neighbors.map(neighbor => `
  381. <div class="interface-item">
  382. <div class="name">${neighbor.remote_device}</div>
  383. <div class="info">
  384. <p>本地接口: ${neighbor.local_interface}</p>
  385. <p>远程接口: ${neighbor.remote_interface}</p>
  386. <p>协议: ${neighbor.protocol}</p>
  387. </div>
  388. </div>
  389. `).join('')}
  390. </div>
  391. `;
  392. detailPanel.classList.add('active');
  393. } catch (error) {
  394. console.error('获取设备详情失败:', error);
  395. }
  396. }
  397. // 添加设备
  398. async function addDevice(event) {
  399. event.preventDefault();
  400. const ip = document.getElementById('device-ip').value;
  401. const type = document.getElementById('device-type').value;
  402. const username = document.getElementById('device-username').value;
  403. const password = document.getElementById('device-password').value;
  404. try {
  405. const response = await fetch('/api/device', {
  406. method: 'POST',
  407. headers: {
  408. 'Content-Type': 'application/json'
  409. },
  410. body: JSON.stringify({
  411. ip: ip,
  412. type: type,
  413. username: username,
  414. password: password
  415. })
  416. });
  417. if (response.ok) {
  418. document.getElementById('modal').classList.remove('active');
  419. document.getElementById('add-device-form').reset();
  420. loadTopology();
  421. loadDeviceList(); // 刷新设备列表
  422. alert('设备添加成功');
  423. } else {
  424. const error = await response.json();
  425. alert('添加失败: ' + error.message);
  426. }
  427. } catch (error) {
  428. console.error('添加设备失败:', error);
  429. alert('添加失败: ' + error.message);
  430. }
  431. }
  432. // 导出拓扑
  433. function exportTopology() {
  434. const json = cy.json();
  435. const dataStr = JSON.stringify(json, null, 2);
  436. const dataBlob = new Blob([dataStr], { type: 'application/json' });
  437. const link = document.createElement('a');
  438. link.href = URL.createObjectURL(dataBlob);
  439. link.download = 'topology.json';
  440. link.click();
  441. }
  442. // 加载拓扑列表
  443. async function loadTopologyList() {
  444. try {
  445. const response = await fetch('/api/topologies');
  446. const topos = await response.json();
  447. const selector = document.getElementById('topology-selector');
  448. selector.innerHTML = '';
  449. if (topos.length === 0) {
  450. selector.innerHTML = '<option value="">暂无拓扑</option>';
  451. return;
  452. }
  453. topos.forEach(topo => {
  454. const option = document.createElement('option');
  455. option.value = topo.id;
  456. option.textContent = `${topo.name} (${topo.device_count || 0} 设备)`;
  457. if (topo.name.includes(' (当前)')) {
  458. option.selected = true;
  459. currentTopologyId = topo.id;
  460. }
  461. selector.appendChild(option);
  462. });
  463. } catch (error) {
  464. console.error('加载拓扑列表失败:', error);
  465. }
  466. }
  467. // 切换拓扑
  468. async function switchTopology(event) {
  469. const topoId = event.target.value;
  470. if (!topoId) return;
  471. try {
  472. const response = await fetch('/api/topology/switch', {
  473. method: 'POST',
  474. headers: {
  475. 'Content-Type': 'application/json'
  476. },
  477. body: JSON.stringify({
  478. topology_id: topoId
  479. })
  480. });
  481. if (response.ok) {
  482. currentTopologyId = topoId;
  483. // 刷新拓扑和设备列表
  484. loadTopology();
  485. loadDeviceList();
  486. } else {
  487. const error = await response.json();
  488. alert('切换失败: ' + error);
  489. }
  490. } catch (error) {
  491. console.error('切换拓扑失败:', error);
  492. alert('切换失败: ' + error.message);
  493. }
  494. }
  495. // 新创建的拓扑ID(用于设备选择器)
  496. let newTopologyId = null;
  497. // 创建拓扑
  498. async function createTopology(event) {
  499. event.preventDefault();
  500. const name = document.getElementById('topo-name').value;
  501. try {
  502. const response = await fetch('/api/topologies', {
  503. method: 'POST',
  504. headers: {
  505. 'Content-Type': 'application/json'
  506. },
  507. body: JSON.stringify({ name: name })
  508. });
  509. if (response.ok) {
  510. const topo = await response.json();
  511. newTopologyId = topo.id;
  512. document.getElementById('modal-new-topology').classList.remove('active');
  513. document.getElementById('new-topology-form').reset();
  514. // 刷新拓扑列表
  515. loadTopologyList();
  516. loadTopology();
  517. loadDeviceList();
  518. // 弹出设备选择器
  519. openDeviceSelector();
  520. } else {
  521. const error = await response.json();
  522. alert('创建失败: ' + error);
  523. }
  524. } catch (error) {
  525. console.error('创建拓扑失败:', error);
  526. alert('创建失败: ' + error.message);
  527. }
  528. }
  529. // ==================== 设备选择器 ====================
  530. // 打开设备选择器
  531. async function openDeviceSelector() {
  532. document.getElementById('modal-select-devices').classList.add('active');
  533. document.getElementById('selected-count').textContent = '已选 0 台';
  534. const poolList = document.getElementById('device-pool-list');
  535. poolList.innerHTML = '<p style="color:#999;text-align:center">加载中...</p>';
  536. try {
  537. const response = await fetch('/api/devices/all');
  538. const devices = await response.json();
  539. poolList.innerHTML = '';
  540. if (devices.length === 0) {
  541. poolList.innerHTML = '<p style="color:#999;text-align:center">暂无设备,请先扫描添加设备</p>';
  542. return;
  543. }
  544. devices.forEach(device => {
  545. const item = document.createElement('div');
  546. item.className = 'device-pool-item';
  547. item.innerHTML = `
  548. <input type="checkbox" value="${device.ip}" onchange="updateSelectedCount()">
  549. <div class="device-info">
  550. <div class="device-ip">${device.ip}</div>
  551. <div class="device-type">${device.type} - ${device.hostname || 'Unknown'}</div>
  552. </div>
  553. `;
  554. // 点击整行切换选中
  555. item.addEventListener('click', function(e) {
  556. if (e.target.tagName !== 'INPUT') {
  557. const cb = item.querySelector('input[type=checkbox]');
  558. cb.checked = !cb.checked;
  559. updateSelectedCount();
  560. }
  561. item.classList.toggle('selected', item.querySelector('input[type=checkbox]').checked);
  562. });
  563. poolList.appendChild(item);
  564. });
  565. } catch (error) {
  566. poolList.innerHTML = '<p style="color:#f44336;text-align:center">加载失败</p>';
  567. console.error('加载设备池失败:', error);
  568. }
  569. }
  570. // 更新选中计数
  571. function updateSelectedCount() {
  572. const checkboxes = document.querySelectorAll('#device-pool-list input[type=checkbox]:checked');
  573. document.getElementById('selected-count').textContent = `已选 ${checkboxes.length} 台`;
  574. }
  575. // 全选/取消全选
  576. function toggleSelectAllDevices(btn) {
  577. const checkboxes = document.querySelectorAll('#device-pool-list input[type=checkbox]');
  578. const allChecked = Array.from(checkboxes).every(cb => cb.checked);
  579. checkboxes.forEach(cb => {
  580. cb.checked = !allChecked;
  581. cb.closest('.device-pool-item').classList.toggle('selected', !allChecked);
  582. });
  583. btn.textContent = allChecked ? '全选' : '取消全选';
  584. updateSelectedCount();
  585. }
  586. // 确认添加设备到拓扑
  587. async function confirmAddDevices() {
  588. const targetTopoId = newTopologyId || currentTopologyId;
  589. if (!targetTopoId) {
  590. alert('请先选择目标拓扑');
  591. return;
  592. }
  593. const checkboxes = document.querySelectorAll('#device-pool-list input[type=checkbox]:checked');
  594. if (checkboxes.length === 0) {
  595. alert('请至少选择一台设备');
  596. return;
  597. }
  598. const deviceIds = Array.from(checkboxes).map(cb => cb.value);
  599. try {
  600. const response = await fetch(`/api/topology/${targetTopoId}/devices`, {
  601. method: 'POST',
  602. headers: { 'Content-Type': 'application/json' },
  603. body: JSON.stringify({ device_ids: deviceIds })
  604. });
  605. if (response.ok) {
  606. const result = await response.json();
  607. document.getElementById('modal-select-devices').classList.remove('active');
  608. newTopologyId = null;
  609. // 刷新界面
  610. loadTopologyList();
  611. loadTopology();
  612. loadDeviceList();
  613. alert(`成功添加 ${result.added} 台设备到 ${result.topology}`);
  614. } else {
  615. alert('添加失败');
  616. }
  617. } catch (error) {
  618. console.error('添加设备失败:', error);
  619. alert('添加失败: ' + error.message);
  620. }
  621. }
  622. // ==================== SSH终端功能 ====================
  623. // 打开SSH终端(先弹出凭据输入框)
  624. function openSSHTerminal(ip, hostname) {
  625. document.getElementById('ssh-target-ip').value = ip;
  626. document.getElementById('ssh-target-username').value = document.getElementById('username').value || 'admin';
  627. document.getElementById('ssh-target-password').value = document.getElementById('password').value || '';
  628. document.getElementById('ssh-target-port').value = document.getElementById('ssh-port').value || '22';
  629. document.getElementById('modal-ssh-creds').classList.add('active');
  630. }
  631. // 连接SSH终端
  632. async function connectTerminal(event) {
  633. event.preventDefault();
  634. const ip = document.getElementById('ssh-target-ip').value;
  635. const port = document.getElementById('ssh-target-port').value || '22';
  636. const username = document.getElementById('ssh-target-username').value;
  637. const password = document.getElementById('ssh-target-password').value;
  638. if (!username || !password) {
  639. alert('请输入用户名和密码');
  640. return;
  641. }
  642. // 关闭凭据弹窗,打开终端弹窗
  643. document.getElementById('modal-ssh-creds').classList.remove('active');
  644. document.getElementById('modal-terminal').classList.add('active');
  645. document.getElementById('terminal-device-name').textContent = ip;
  646. document.getElementById('terminal-status').textContent = '连接中...';
  647. document.getElementById('terminal-status').className = 'terminal-status';
  648. // 初始化 xterm.js
  649. if (currentTerminal) {
  650. currentTerminal.dispose();
  651. }
  652. const term = new Terminal({
  653. cursorBlink: true,
  654. fontSize: 14,
  655. fontFamily: 'Consolas, "Courier New", monospace',
  656. theme: {
  657. background: '#1e1e1e',
  658. foreground: '#d4d4d4',
  659. cursor: '#d4d4d4'
  660. }
  661. });
  662. const fitAddon = new FitAddon.FitAddon();
  663. term.loadAddon(fitAddon);
  664. const terminalContainer = document.getElementById('terminal-container');
  665. terminalContainer.innerHTML = '';
  666. term.open(terminalContainer);
  667. fitAddon.fit();
  668. currentTerminal = term;
  669. // 构建WebSocket URL
  670. const wsProtocol = window.location.protocol === 'https:' ? 'wss:' : 'ws:';
  671. const wsUrl = `${wsProtocol}//${window.location.host}/api/terminal?ip=${encodeURIComponent(ip)}&port=${encodeURIComponent(port)}&username=${encodeURIComponent(username)}&password=${encodeURIComponent(password)}`;
  672. let ws;
  673. try {
  674. ws = new WebSocket(wsUrl);
  675. } catch (e) {
  676. term.writeln('连接失败: ' + e.message);
  677. document.getElementById('terminal-status').textContent = '连接失败';
  678. return;
  679. }
  680. ws.onopen = function() {
  681. document.getElementById('terminal-status').textContent = '已连接';
  682. document.getElementById('terminal-status').className = 'terminal-status connected';
  683. term.writeln('\x1b[32m--- SSH 连接已建立 ---\x1b[0m');
  684. term.focus();
  685. fitAddon.fit();
  686. };
  687. ws.onmessage = function(event) {
  688. term.write(event.data);
  689. };
  690. ws.onclose = function() {
  691. document.getElementById('terminal-status').textContent = '已断开';
  692. document.getElementById('terminal-status').className = 'terminal-status';
  693. term.writeln('\r\n\x1b[31m--- 连接已断开 ---\x1b[0m');
  694. };
  695. ws.onerror = function(err) {
  696. document.getElementById('terminal-status').textContent = '连接错误';
  697. document.getElementById('terminal-status').className = 'terminal-status';
  698. term.writeln('\r\n\x1b[31m--- 连接错误 ---\x1b[0m');
  699. };
  700. // 终端输入转发到WebSocket
  701. term.onData(function(data) {
  702. if (ws && ws.readyState === WebSocket.OPEN) {
  703. ws.send(JSON.stringify({ input: data }));
  704. }
  705. });
  706. // 终端resize通知
  707. term.onResize(function(size) {
  708. if (ws && ws.readyState === WebSocket.OPEN) {
  709. ws.send(JSON.stringify({ type: 'resize', cols: size.cols, rows: size.rows }));
  710. }
  711. });
  712. // 窗口resize时自动调整
  713. const resizeObserver = new ResizeObserver(function() {
  714. fitAddon.fit();
  715. });
  716. resizeObserver.observe(terminalContainer);
  717. // 存储ws引用以便关闭
  718. term._ws = ws;
  719. term._resizeObserver = resizeObserver;
  720. }
  721. // 关闭终端
  722. function closeTerminal() {
  723. if (currentTerminal) {
  724. if (currentTerminal._ws) {
  725. currentTerminal._ws.close();
  726. }
  727. if (currentTerminal._resizeObserver) {
  728. currentTerminal._resizeObserver.disconnect();
  729. }
  730. currentTerminal.dispose();
  731. currentTerminal = null;
  732. }
  733. document.getElementById('modal-terminal').classList.remove('active');
  734. document.getElementById('terminal-container').innerHTML = '';
  735. // 重置终端模态框位置
  736. var modal = document.querySelector('.terminal-modal-content');
  737. if (modal) {
  738. modal.style.position = '';
  739. modal.style.left = '';
  740. modal.style.top = '';
  741. modal.style.margin = '';
  742. }
  743. }
  744. // 删除设备
  745. async function deleteDevice(deviceId) {
  746. if (!confirm('确定要删除设备 ' + deviceId + ' 吗?')) return;
  747. try {
  748. const response = await fetch(`/api/device/${deviceId}`, {
  749. method: 'DELETE'
  750. });
  751. if (response.ok) {
  752. alert('删除成功');
  753. document.getElementById('detail-panel').classList.remove('active');
  754. // 重新加载拓扑和设备列表
  755. loadTopology();
  756. loadDeviceList();
  757. } else {
  758. alert('删除失败');
  759. }
  760. } catch (error) {
  761. alert('删除失败: ' + error.message);
  762. }
  763. }
  764. // 打开编辑设备模态框
  765. function openEditDevice(id, hostname, type) {
  766. document.getElementById('edit-device-id').value = id;
  767. document.getElementById('edit-hostname').value = hostname;
  768. document.getElementById('edit-type').value = type;
  769. document.getElementById('modal-edit-device').classList.add('active');
  770. }
  771. // 保存编辑设备
  772. async function saveEditDevice(event) {
  773. event.preventDefault();
  774. const id = document.getElementById('edit-device-id').value;
  775. const hostname = document.getElementById('edit-hostname').value;
  776. const type = document.getElementById('edit-type').value;
  777. try {
  778. const response = await fetch(`/api/device/${id}`, {
  779. method: 'PUT',
  780. headers: { 'Content-Type': 'application/json' },
  781. body: JSON.stringify({ hostname, type })
  782. });
  783. if (response.ok) {
  784. alert('修改成功');
  785. document.getElementById('modal-edit-device').classList.remove('active');
  786. document.getElementById('detail-panel').classList.remove('active');
  787. loadTopology();
  788. loadDeviceList();
  789. } else {
  790. const data = await response.json();
  791. alert('修改失败: ' + (data.error || '未知错误'));
  792. }
  793. } catch (error) {
  794. alert('修改失败: ' + error.message);
  795. }
  796. }
  797. // 面板拖拽调整大小功能
  798. (function() {
  799. // 左侧面板拖拽
  800. var resizerLeft = document.getElementById('resizer-left');
  801. var sidebar = document.getElementById('sidebar');
  802. if (resizerLeft && sidebar) {
  803. var isResizingLeft = false;
  804. resizerLeft.addEventListener('mousedown', function(e) {
  805. isResizingLeft = true;
  806. resizerLeft.classList.add('resizing');
  807. document.body.style.cursor = 'col-resize';
  808. document.body.style.userSelect = 'none';
  809. e.preventDefault();
  810. });
  811. document.addEventListener('mousemove', function(e) {
  812. if (!isResizingLeft) return;
  813. var newWidth = e.clientX;
  814. var minWidth = 200;
  815. var maxWidth = 600;
  816. if (newWidth >= minWidth && newWidth <= maxWidth) {
  817. sidebar.style.width = newWidth + 'px';
  818. }
  819. });
  820. document.addEventListener('mouseup', function() {
  821. if (isResizingLeft) {
  822. isResizingLeft = false;
  823. resizerLeft.classList.remove('resizing');
  824. document.body.style.cursor = '';
  825. document.body.style.userSelect = '';
  826. }
  827. });
  828. }
  829. // 右侧面板拖拽
  830. var resizerRight = document.getElementById('resizer-right');
  831. var detailPanel = document.getElementById('detail-panel');
  832. if (resizerRight && detailPanel) {
  833. var isResizingRight = false;
  834. resizerRight.addEventListener('mousedown', function(e) {
  835. isResizingRight = true;
  836. resizerRight.classList.add('resizing');
  837. document.body.style.cursor = 'col-resize';
  838. document.body.style.userSelect = 'none';
  839. e.preventDefault();
  840. });
  841. document.addEventListener('mousemove', function(e) {
  842. if (!isResizingRight) return;
  843. var containerWidth = document.querySelector('.main-content').offsetWidth;
  844. var newWidth = containerWidth - e.clientX;
  845. var minWidth = 300;
  846. var maxWidth = 1000;
  847. if (newWidth >= minWidth && newWidth <= maxWidth) {
  848. detailPanel.style.width = newWidth + 'px';
  849. }
  850. });
  851. document.addEventListener('mouseup', function() {
  852. if (isResizingRight) {
  853. isResizingRight = false;
  854. resizerRight.classList.remove('resizing');
  855. document.body.style.cursor = '';
  856. document.body.style.userSelect = '';
  857. }
  858. });
  859. }
  860. })();