diff --git a/src/pages/Index/Regular/Consumables.vue b/src/pages/Index/Regular/Consumables.vue index b71af58..0416a55 100644 --- a/src/pages/Index/Regular/Consumables.vue +++ b/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() -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;