防止提示过多

src/pages/Index/Regular/Consumables.vue

@@ -129,14 +129,12 @@ import { useConsumablesStore, useEmergencyStore } from '@/store'
 import { useDeviceStore } from '@/store/index'
 import { eventBus } from '@/eventBus'
 import { createWebSocket } from '@/websocket/socket'
-import type {
-  ConsumablesStateMessage,
-} from '@/websocket/socket'
+import type { ConsumablesStateMessage } from '@/websocket/socket'
 import InitWarn from '../components/Consumables/Warn/InitWarn.vue'
 import { getServerInfo } from '@/utils/getServerInfo'
 import { formatScanReports } from '@/utils/errorHandler'
 import { ElMessage } from 'element-plus'
-import { Subject, debounceTime } from 'rxjs'
+import { Subject, throttleTime } from 'rxjs'
 
 const { wsUrl } = getServerInfo('/api/v1/app/ws/state')
 const socket = createWebSocket(wsUrl)
@@ -146,7 +144,7 @@ const emergencyStore = useEmergencyStore()
 const deviceStore = useDeviceStore()
 
 const errMsg$ = new Subject<string>()
-errMsg$.pipe(debounceTime(500)).subscribe((msg) => {
+errMsg$.pipe(throttleTime(800)).subscribe((msg) => {
   ElMessage.error(msg)
 })
 // 扫描耗材中
@@ -192,7 +190,7 @@ let hasAllConsumables = ref(false)
 //处理耗材状态
 let allowDel = 0
 const handleConsumablesState = (data: ConsumablesStateMessage['data']) => {
-  if(!allowDel){
+  if (!allowDel) {
     console.log('耗材日志------', data)
   }
   allowDel = 1
@@ -201,7 +199,7 @@ const handleConsumablesState = (data: ConsumablesStateMessage['data']) => {
     // if(
     //     (data.tips && data.tips.length ) &&
     //     (data.reactionPlateGroup && data.reactionPlateGroup.length) &&
-    //     (data.littBottleGroup && data.littBottleGroup.length) && 
+    //     (data.littBottleGroup && data.littBottleGroup.length) &&
     //     (data.larBottleGroup && data.larBottleGroup.length)
     //   ){
     //     hasAllConsumables.value = true;