feat: 添加图像发送控制和系统清零使能功能，更新IPC事件处理

src/main/ipcRouter.js

@@ -32,8 +32,10 @@ export function registerIpRouter() {
   ipcMain.handle(IPC_EVENT.VIDEO_FPS_SET, videoFpsSet)
   ipcMain.handle(IPC_EVENT.THRESHOLD_SET, thresholdSet)
   ipcMain.handle(IPC_EVENT.INVALID_DATA_COUNT_SET, invalidDataCountSet)
+  ipcMain.handle(IPC_EVENT.IMAGE_SEND_ENABLED, imageSendEnabledSet)
+  ipcMain.handle(IPC_EVENT.IS_CLEAR_ZERO, isClearZeroSet)
 }
-
+// 搜索设备
 const searchDevice = (event) => {
   const message = Buffer.from(JSON.stringify({ command: 'name', type: 'get' }))
   const PORT = 2230
@@ -79,6 +81,7 @@ const searchDevice = (event) => {
   })
 }
 
+// 连接设备
 const connectDevice = (event, { ip, port }) => {
   if (!ip || !port) {
     event.reply(IPC_EVENT.DEVICE_CONNECT_REPLY, { success: false, error: '参数缺失' })
@@ -117,7 +120,6 @@ const connectDevice = (event, { ip, port }) => {
       let msg
       try {
         msg = JSON.parse(line)
-        console.log('Received command:', `${msg.command}:${msg.type}`)
       } catch (e) {
         console.error('TCP data parse error:', e)
         fs.appendFileSync('error_log.txt', line + '\n')
@@ -125,7 +127,7 @@ const connectDevice = (event, { ip, port }) => {
       }
 
       if (!msg || !msg.command) {
-        console.log('invalid msg format:', msg)
+        console.warn('invalid msg format:', msg)
         continue
       }
 
@@ -148,6 +150,7 @@ const connectDevice = (event, { ip, port }) => {
   })
 }
 
+// 断开连接
 const disconnectDevice = (event, { ip }) => {
   const connectionInfo = tcpClients.get(ip)
   if (connectionInfo) {
@@ -200,7 +203,6 @@ const handleTcpResponse = async (ip, msg) => {
         if (imageTimeRequest) {
           // 响应图像发送间隔获取请求
           await delay()
-          console.log(msg)
           imageTimeRequest.resolve({ success: true, data: msg })
 
           pendingRequests.delete(`${ip}${IPC_EVENT.IMAGE_SEND_TIME_GET}`)
@@ -213,7 +215,6 @@ const handleTcpResponse = async (ip, msg) => {
         if (imageTimeRequest) {
           // 响应图像发送间隔设置请求
           await delay()
-          console.log(msg)
           imageTimeRequest.resolve({ success: true, data: msg })
           pendingRequests.delete(`${ip}${IPC_EVENT.IMAGE_SEND_TIME_SET}`)
         }
@@ -225,7 +226,6 @@ const handleTcpResponse = async (ip, msg) => {
         const paramRequest = pendingRequests.get(`${ip}${IPC_EVENT.ZERO_COUNT_GET}`)
         if (paramRequest) {
           await delay()
-          console.log(msg)
           paramRequest.resolve({ success: true, data: msg })
           pendingRequests.delete(`${ip}${IPC_EVENT.ZERO_COUNT_GET}`)
         }
@@ -236,7 +236,6 @@ const handleTcpResponse = async (ip, msg) => {
         const paramRequest = pendingRequests.get(`${ip}${IPC_EVENT.RESULT_COUNT_GET}`)
         if (paramRequest) {
           await delay()
-          console.log(msg)
           paramRequest.resolve({ success: true, data: msg })
           pendingRequests.delete(`${ip}${IPC_EVENT.RESULT_COUNT_GET}`)
         }
@@ -247,7 +246,6 @@ const handleTcpResponse = async (ip, msg) => {
         const paramRequest = pendingRequests.get(`${ip}${IPC_EVENT.DATA_FPS_GET}`)
         if (paramRequest) {
           await delay()
-          console.log(msg)
           paramRequest.resolve({ success: true, data: msg })
           pendingRequests.delete(`${ip}${IPC_EVENT.DATA_FPS_GET}`)
         }
@@ -258,7 +256,6 @@ const handleTcpResponse = async (ip, msg) => {
         const paramRequest = pendingRequests.get(`${ip}${IPC_EVENT.VIDEO_FPS_GET}`)
         if (paramRequest) {
           await delay()
-          console.log(msg)
           paramRequest.resolve({ success: true, data: msg })
           pendingRequests.delete(`${ip}${IPC_EVENT.VIDEO_FPS_GET}`)
         }
@@ -269,7 +266,6 @@ const handleTcpResponse = async (ip, msg) => {
         const paramRequest = pendingRequests.get(`${ip}${IPC_EVENT.THRESHOLD_GET}`)
         if (paramRequest) {
           await delay()
-          console.log(msg)
           paramRequest.resolve({ success: true, data: msg })
           pendingRequests.delete(`${ip}${IPC_EVENT.THRESHOLD_GET}`)
         }
@@ -280,7 +276,6 @@ const handleTcpResponse = async (ip, msg) => {
         const paramRequest = pendingRequests.get(`${ip}${IPC_EVENT.INVALID_DATA_COUNT_GET}`)
         if (paramRequest) {
           await delay()
-          console.log(msg)
           paramRequest.resolve({ success: true, data: msg })
           pendingRequests.delete(`${ip}${IPC_EVENT.INVALID_DATA_COUNT_GET}`)
         }
@@ -292,7 +287,6 @@ const handleTcpResponse = async (ip, msg) => {
         const paramRequest = pendingRequests.get(`${ip}${IPC_EVENT.ZERO_COUNT_SET}`)
         if (paramRequest) {
           await delay()
-          console.log(msg)
           paramRequest.resolve({ success: true, data: msg })
           pendingRequests.delete(`${ip}${IPC_EVENT.ZERO_COUNT_SET}`)
         }
@@ -303,7 +297,6 @@ const handleTcpResponse = async (ip, msg) => {
         const paramRequest = pendingRequests.get(`${ip}${IPC_EVENT.RESULT_COUNT_SET}`)
         if (paramRequest) {
           await delay()
-          console.log(msg)
           paramRequest.resolve({ success: true, data: msg })
           pendingRequests.delete(`${ip}${IPC_EVENT.RESULT_COUNT_SET}`)
         }
@@ -314,7 +307,6 @@ const handleTcpResponse = async (ip, msg) => {
         const paramRequest = pendingRequests.get(`${ip}${IPC_EVENT.DATA_FPS_SET}`)
         if (paramRequest) {
           await delay()
-          console.log(msg)
           paramRequest.resolve({ success: true, data: msg })
           pendingRequests.delete(`${ip}${IPC_EVENT.DATA_FPS_SET}`)
         }
@@ -325,7 +317,6 @@ const handleTcpResponse = async (ip, msg) => {
         const paramRequest = pendingRequests.get(`${ip}${IPC_EVENT.VIDEO_FPS_SET}`)
         if (paramRequest) {
           await delay()
-          console.log(msg)
           paramRequest.resolve({ success: true, data: msg })
           pendingRequests.delete(`${ip}${IPC_EVENT.VIDEO_FPS_SET}`)
         }
@@ -336,7 +327,6 @@ const handleTcpResponse = async (ip, msg) => {
         const paramRequest = pendingRequests.get(`${ip}${IPC_EVENT.THRESHOLD_SET}`)
         if (paramRequest) {
           await delay()
-          console.log(msg)
           paramRequest.resolve({ success: true, data: msg })
           pendingRequests.delete(`${ip}${IPC_EVENT.THRESHOLD_SET}`)
         }
@@ -347,12 +337,33 @@ const handleTcpResponse = async (ip, msg) => {
         const paramRequest = pendingRequests.get(`${ip}${IPC_EVENT.INVALID_DATA_COUNT_SET}`)
         if (paramRequest) {
           await delay()
-          console.log(msg)
           paramRequest.resolve({ success: true, data: msg })
           pendingRequests.delete(`${ip}${IPC_EVENT.INVALID_DATA_COUNT_SET}`)
         }
       }
       break
+    case IPC_EVENT.IMAGE_SEND_ENABLED:
+      {
+        const imageSendRequest = pendingRequests.get(`${ip}${IPC_EVENT.IMAGE_SEND_ENABLED}`)
+        if (imageSendRequest) {
+          // 响应图像发送设置请求
+          await delay()
+          imageSendRequest.resolve({ success: true, data: msg })
+          pendingRequests.delete(`${ip}${IPC_EVENT.IMAGE_SEND_ENABLED}`)
+        }
+      }
+      break
+    case IPC_EVENT.IS_CLEAR_ZERO:
+      {
+        const clearZeroRequest = pendingRequests.get(`${ip}${IPC_EVENT.IS_CLEAR_ZERO}`)
+        if (clearZeroRequest) {
+          // 响应清零使能设置请求
+          await delay()
+          clearZeroRequest.resolve({ success: true, data: msg })
+          pendingRequests.delete(`${ip}${IPC_EVENT.IS_CLEAR_ZERO}`)
+        }
+      }
+      break
     case IPC_EVENT.HEARTBEAT_REPLY:
       // 心跳处理
       break
@@ -768,7 +779,6 @@ const dataFpsSet = async (event, { ip, value }) => {
 
     const command = { command: 'dataFps', type: 'set', values: value }
     const message = JSON.stringify(command) + END_SEQUENCE
-    console.log('Sending command:', message)
     connectionInfo.client.write(message, (err) => {
       if (err) {
         pendingRequests.delete(requestKey)
@@ -1018,6 +1028,82 @@ const invalidDataCountSet = async (event, { ip, value }) => {
     })
   })
 }
+// 图像发送使能设置
+const imageSendEnabledSet = async (event, { ip, value }) => {
+  return new Promise((resolve, reject) => {
+    const connectionInfo = tcpClients.get(ip)
+    if (!connectionInfo) {
+      resolve({ success: false, error: '设备未连接' })
+      return
+    }
+
+    const requestKey = `${ip}${IPC_EVENT.IMAGE_SEND_ENABLED}`
+    const timeout = setTimeout(() => {
+      pendingRequests.delete(requestKey)
+      resolve({ success: false, error: '请求超时' })
+    }, TIMEOUT)
+
+    pendingRequests.set(requestKey, {
+      resolve: (result) => {
+        clearTimeout(timeout)
+        resolve(result)
+      },
+      reject: (error) => {
+        clearTimeout(timeout)
+        reject(error)
+      },
+      timestamp: Date.now()
+    })
+
+    const command = { command: 'imageSendEnabled', type: 'set', values: value }
+    const message = JSON.stringify(command) + END_SEQUENCE
+
+    connectionInfo.client.write(message, (err) => {
+      if (err) {
+        pendingRequests.delete(requestKey)
+        clearTimeout(timeout)
+        resolve({ success: false, error: err.message })
+      }
+    })
+  })
+}
+const isClearZeroSet = async (event, { ip, value }) => {
+  return new Promise((resolve, reject) => {
+    const connectionInfo = tcpClients.get(ip)
+    if (!connectionInfo) {
+      resolve({ success: false, error: '设备未连接' })
+      return
+    }
+
+    const requestKey = `${ip}${IPC_EVENT.IS_CLEAR_ZERO}`
+    const timeout = setTimeout(() => {
+      pendingRequests.delete(requestKey)
+      resolve({ success: false, error: '请求超时' })
+    }, TIMEOUT)
+
+    pendingRequests.set(requestKey, {
+      resolve: (result) => {
+        clearTimeout(timeout)
+        resolve(result)
+      },
+      reject: (error) => {
+        clearTimeout(timeout)
+        reject(error)
+      },
+      timestamp: Date.now()
+    })
+
+    const command = { command: 'isClearZero', type: 'set', values: value }
+    const message = JSON.stringify(command) + END_SEQUENCE
+    connectionInfo.client.write(message, (err) => {
+      if (err) {
+        pendingRequests.delete(requestKey)
+        clearTimeout(timeout)
+        resolve({ success: false, error: err.message })
+      }
+    })
+  })
+}
 
 // 清理指定IP的所有待处理请求
 const clearPendingRequestsByIp = (ip) => {

src/renderer/src/common/ipcEvents.js

@@ -11,7 +11,9 @@ export const IPC_EVENT = {
   IMAGE_REPLY: 'image:reply', // 图像数据
   HEARTBEAT_REPLY: 'heartbeat:reply', // 心跳包
   SENSORS_GET: 'sensors:get', // 加载传感器配置
-  SENSORS_SET: 'sensors:set', // 加载传感器配置
+  SENSORS_SET: 'sensors:set', // 设置传感器配置
+  IMAGE_SEND_ENABLED: 'imageSendEnabled:set', // 图像发送设置
+  IS_CLEAR_ZERO: 'isClearZero:set', // 系统清零使能
 
   // 基本参数相关,GET
   IMAGE_SEND_TIME_GET: 'imageSendTime:get',

src/renderer/src/components/SystemSettings/SystemSettings.jsx

@@ -18,6 +18,8 @@ function SystemSettings() {
   const [paramValue, setParamValue] = useState('')
   const [loading, setLoading] = useState(false)
   const [settingLoading, setSettingLoading] = useState(false)
+  const [imageControlLoading, setImageControlLoading] = useState(false)
+  const [clearZeroLoading, setClearZeroLoading] = useState(false)
 
   // 获取设备连接状态
   const connectedDevice = useDeviceStore((state) => state.connectedDevice)
@@ -149,6 +151,60 @@ function SystemSettings() {
     }
   }
 
+  // 图片发送控制函数
+  const handleImageSendControl = async (enabled) => {
+    if (!connectedDevice || !connectedDevice.ip) {
+      message.warning('请先连接设备！')
+      return
+    }
+
+    setImageControlLoading(true)
+    try {
+      const result = await window.electron.ipcRenderer.invoke(IPC_EVENT.IMAGE_SEND_ENABLED, {
+        ip: connectedDevice.ip,
+        value: enabled
+      })
+
+      if (result.success) {
+        message.success(`${enabled ? '开始' : '停止'}发送图片成功！`)
+      } else {
+        message.error(`操作失败：${result.error}`)
+      }
+    } catch (error) {
+      console.error('图片发送控制失败:', error)
+      message.error(`操作失败：${error.message}`)
+    } finally {
+      setImageControlLoading(false)
+    }
+  }
+
+  // 系统清零使能函数
+  const handleClearZero = async () => {
+    if (!connectedDevice || !connectedDevice.ip) {
+      message.warning('请先连接设备！')
+      return
+    }
+
+    setClearZeroLoading(true)
+    try {
+      const result = await window.electron.ipcRenderer.invoke(IPC_EVENT.IS_CLEAR_ZERO, {
+        ip: connectedDevice.ip,
+        value: true
+      })
+
+      if (result.success) {
+        message.success('系统清零使能成功！')
+      } else {
+        message.error(`操作失败：${result.error}`)
+      }
+    } catch (error) {
+      console.error('系统清零使能失败:', error)
+      message.error(`操作失败：${error.message}`)
+    } finally {
+      setClearZeroLoading(false)
+    }
+  }
+
   return (
     <Flex vertical gap={4} className={styles.container}>
       <div className={styles.header}>
@@ -212,13 +268,31 @@ function SystemSettings() {
         <div className={styles.subSection}>
           <div className={styles.subSectionTitle}>系统功能</div>
           <Flex vertical gap={4}>
-            <Button className={styles.systemButton} block>
+            <Button
+              className={styles.systemButton}
+              block
+              loading={clearZeroLoading}
+              disabled={!connectedDevice}
+              onClick={handleClearZero}
+            >
               系统清零使能
             </Button>
-            <Button className={styles.systemButton} block>
+            <Button
+              className={styles.systemButton}
+              block
+              loading={imageControlLoading}
+              disabled={!connectedDevice}
+              onClick={() => handleImageSendControl(true)}
+            >
               开始发送图片
             </Button>
-            <Button className={styles.systemButton} block>
+            <Button
+              className={styles.systemButton}
+              block
+              loading={imageControlLoading}
+              disabled={!connectedDevice}
+              onClick={() => handleImageSendControl(false)}
+            >
               停止发送图片
             </Button>
           </Flex>