feat: 批量指令展示逻辑优化

server/app/controller/onekey.js

@@ -6,7 +6,7 @@ async function getOnekeyRecord({ res }) {
   data = data.map(item => {
     return { ...item, id: item._id }
   })
-  data?.sort((a, b) => Number(b.date) - Number(a.date))
+  data?.sort((a, b) => Number(b.startDate) - Number(a.startDate))
   res.success({ data })
 }
 

server/app/socket/onekey.js

@@ -52,7 +52,7 @@ function execShell(socket, sshClient, curRes, resolve) {
     //   arrayBuffers: (memoryUsage.arrayBuffers / 1024 / 1024).toFixed(2) + ' MB' // Memory allocated for ArrayBuffer and SharedArrayBuffer, including all Node.js Buffers
     // }
     // console.log(formattedMemoryUsage)
-  }, 500) // 防止内存爆破
+  }, 1000) // 防止内存爆破
   sshClient.exec(curRes.command, function(err, stream) {
     if (err) {
       console.log(curRes.host, '命令执行失败:', err)
@@ -134,7 +134,7 @@ module.exports = (httpServer) => {
         return new Promise(async (resolve, reject) => {
           setTimeout(() => reject('执行超时'), timeout * 1000)
           let { host, port, jumpHosts } = hostInfo
-          let curRes = { command, host, port, name: hostInfo.name, result: '', status: execStatusEnum.connecting, date: Date.now() - (targetHostsInfo.length - index) }
+          let curRes = { command, host, port, name: hostInfo.name, result: '', status: execStatusEnum.connecting, startDate: Date.now() + index }
           execResult.push(curRes)
           let jumpSshClients = []
           try {
@@ -218,6 +218,7 @@ module.exports = (httpServer) => {
         if (reason !== 'server namespace disconnect' && ![execSuccess, execFail, execTimeout, connectFail].includes(item.status)) {
           item.status = execStatusEnum.socketInterrupt
         }
+        item.endDate = Date.now()
       })
       await onekeyDB.insertAsync(execResult)
       isExecuting = false

web/src/views/onekey/index.vue

@@ -9,6 +9,14 @@
       >
         {{ isExecuting ? `执行中，剩余${timeRemaining}秒` : '批量下发指令' }}
       </el-button>
+      <!-- <el-button
+        v-show="recordList.length"
+        :disabled="isExecuting"
+        type="primary"
+        @click="handleRefresh"
+      >
+        刷新列表
+      </el-button> -->
       <el-button
         v-show="recordList.length"
         :disabled="isExecuting"
@@ -22,7 +30,7 @@
     <el-table
       v-loading="loading"
       :data="tableData"
-      row-key="id"
+      row-key="startDate"
       :expand-row-keys="expandRows"
     >
       <el-table-column type="expand">
@@ -54,6 +62,26 @@
           <span> {{ row.command }} </span>
         </template>
       </el-table-column>
+      <el-table-column
+        prop="startDate"
+        label="开始时间"
+        show-overflow-tooltip
+        min-width="150px"
+      >
+        <template #default="{ row }">
+          <span> {{ $tools.formatTimestamp(row.startDate) }} </span>
+        </template>
+      </el-table-column>
+      <el-table-column
+        prop="endDate"
+        label="结束时间"
+        show-overflow-tooltip
+        min-width="150px"
+      >
+        <template #default="{ row }">
+          <span> {{ $tools.formatTimestamp(row.endDate) }} </span>
+        </template>
+      </el-table-column>
       <el-table-column
         prop="status"
         label="执行结果"
@@ -183,7 +211,7 @@ import { useRoute } from 'vue-router'
 
 const { io } = socketIo
 
-const { proxy: { $api, $notification,$messageBox, $message, $router, $serviceURI, $store } } = getCurrentInstance()
+const { proxy: { $api, $notification,$messageBox, $message, $router, $serviceURI, $store, $tools } } = getCurrentInstance()
 const route = useRoute()
 
 const loading = ref(false)
@@ -216,7 +244,7 @@ const tableData = computed(() => {
   })
 })
 const expandRows = computed(() => {
-  let rows = tableData.value.filter(item => item.pending).map(item => item.id)
+  let rows = tableData.value.filter(item => item.pending).map(item => item.startDate)
   return rows
 })
 
@@ -281,11 +309,7 @@ const createExecShell = (hostIds = [], command = 'ls', timeout = 60) => {
         message: reason,
         type: 'error'
       })
-      if (Array.isArray(result) && result.length > 0) {
-        // console.log('output', result)
-        result = result.map(item => ({ ...item, pending: true }))
-        pendingRecord.value = result
-      }
+      getOnekeyRecord()
     })
 
     socket.value.on('token_verify_fail', () => {
@@ -299,6 +323,7 @@ const createExecShell = (hostIds = [], command = 'ls', timeout = 60) => {
         message: '执行完成',
         type: 'success'
       })
+      getOnekeyRecord()
     })
   })
 
@@ -365,6 +390,7 @@ let getOnekeyRecord = async () => {
   loading.value = true
   let { data } = await $api.getOnekeyRecord()
   recordList.value = data
+  pendingRecord.value = []
   loading.value = false
 }
 
@@ -443,9 +469,6 @@ onActivated(async () => {
     display: flex;
     align-items: center;
     justify-content: end;
-    position: sticky;
-    top: 0;
-    z-index: 1;
   }
   .detail_content_box {
     max-height: 200px;