diff --git a/klp-ui/src/views/wms/print/scaner.vue b/klp-ui/src/views/wms/print/scaner.vue index 39835727..41e644ad 100644 --- a/klp-ui/src/views/wms/print/scaner.vue +++ b/klp-ui/src/views/wms/print/scaner.vue @@ -41,12 +41,14 @@ - + + + + + + + + @@ -99,7 +101,7 @@ - + @@ -164,15 +166,15 @@ export default { initSocket() { // 处理WebSocket连接 this.socket = new WebSocket("ws://localhost:9000/ws"); - + this.socket.onopen = () => { console.log("Socket 连接已建立"); }; - + this.socket.onmessage = (event) => { try { const data = JSON.parse(event.data); - + // 处理设备列表数据 if (data.type === "allDevices") { console.log("获取设备列表", data); @@ -181,7 +183,7 @@ export default { totalCount: data.totalCount || 0, activeCount: data.activeCount || 0 }; - } + } // 处理扫描消息 else if (data.type === "scanMessage") { console.log("获取扫描消息", data); @@ -201,7 +203,7 @@ export default { console.error("解析WebSocket消息失败", error); } }; - + this.socket.onclose = () => { console.log("Socket 连接已关闭"); // 连接关闭后尝试重连 @@ -209,12 +211,12 @@ export default { this.initSocket(); }, 5000); }; - + this.socket.onerror = (error) => { console.error("Socket 错误", error); }; }, - + // 刷新设备列表 refreshDevices() { if (this.socket && this.socket.readyState === WebSocket.OPEN) { @@ -225,7 +227,7 @@ export default { this.initSocket(); } }, - + fetchMaster() { listStockIo({ pageSize: 9999, pageNum: 1 }).then(res => { console.log("获取挂载单据", res); @@ -235,7 +237,7 @@ export default { this.$message.error("获取挂载单据失败"); }); }, - + handleDeviceChange(item) { this.socket.send( JSON.stringify({ @@ -244,7 +246,7 @@ export default { }) ); }, - + handleBatchConfirm() { // 汇总会导致的库存变更,需要确认 console.log("批量确认", this.selectedList); @@ -252,7 +254,7 @@ export default { this.$message.warning("请选择需要确认的记录"); return; } - + // 批量处理逻辑 Promise.all(this.selectedList.map(item => this.processRecord(item))) .then(() => { @@ -268,15 +270,15 @@ export default { this.$message.error("批量确认失败"); }); }, - + handleSelectionChange(selection) { this.selectedList = selection; }, - + handleDelete(row) { this.messageList = this.messageList.filter(item => item.time !== row.time); }, - + async handleConfirm(row) { try { await this.processRecord(row); @@ -287,7 +289,7 @@ export default { this.$message.error('确认失败'); } }, - + // 处理单条记录的确认逻辑 async processRecord(row) { // 插入记录 @@ -295,11 +297,11 @@ export default { // 更新库存 await this.updateStock(row); }, - + insertRecord(row) { return addStockIoDetail(row); }, - + updateStock(row) { if (row.ioType === 'in') { return scanInStock(row); @@ -483,4 +485,4 @@ export default { .el-table td, .el-table th { padding: 12px 0; } - \ No newline at end of file +