From 8d58c40af40493bd5f066cbfdb1ffd9f113c22fc Mon Sep 17 00:00:00 2001
From: 严智鑫 <test>
Date: 星期三, 03 九月 2025 16:37:21 +0800
Subject: [PATCH] 1.前端推数据使用了最新的webSokect客户现场总是掉线,修改为接口方式 2.设备交互整体增加异常处理以及PLC连接方式改为短连接

---
 UI-Project/src/views/ManualReporting/manualReporting.vue |  162 ++++++++++++++++++++++++++++++++++++-----------------
 1 files changed, 110 insertions(+), 52 deletions(-)

diff --git a/UI-Project/src/views/ManualReporting/manualReporting.vue b/UI-Project/src/views/ManualReporting/manualReporting.vue
index c7c992c..662c7cf 100644
--- a/UI-Project/src/views/ManualReporting/manualReporting.vue
+++ b/UI-Project/src/views/ManualReporting/manualReporting.vue
@@ -16,7 +16,7 @@
 const blind = ref(false)
 const errorInfo = ref(true)
 const loadData = ref([]);
-const taskinggoruby = ref([]);
+
 const findMachine = ref([]);
 const sendRecords = ref([]);
 const downLineTask = ref([]);
@@ -31,57 +31,122 @@
 console.log(machineId);
 var errorScanId;
 var errorOpen=false;
-//浣跨敤WebSocket鏂瑰紡灞曠ず鏁版嵁
-let socket = null;
-let socketDownLineTask = null;
-const socketUrl = `ws://${WebSocketHost}:${host}/api/deviceInteraction/api/talk/manualReporting`;
-const socketDownLineTaskUrl = `ws://${WebSocketHost}:${host}/api/deviceInteraction/api/talk/downLineTask`;
-// 瀹氫箟娑堟伅澶勭悊鍑芥暟锛屾洿鏂� receivedData 鍙橀噺
-const handleMessage = (data) => {
-  // 鏇存柊 tableData 鐨勬暟鎹�
-  //taskinggoruby.value = data.taskinggoruby[0];
-  //loadData.value =getDataSort(data.taskingList[0]);
-  const dataJson = data[""+machineId][0];
-  loadData.value = dataJson.taskingList[0];
-  findMachine.value = dataJson.machine[0];
-  
-  if(findMachine.value.remark.toString()!=errorScanId&&findMachine.value.remark.toString()!=""&&findMachine.value.remark.toString()!=undefined){
-    //鏈夋暟鎹氨寮圭獥 
-    if(errorOpen){
-      ElMessageBox.close();
+// 鍒嗙粍鍚庣殑缁熻鏁版嵁
+const taskingGroupBy = ref([]);
+// 鍒嗙粍骞剁粺璁$殑鏂规硶
+const groupAndCount = () => {
+  // 鍒涘缓涓�涓复鏃跺璞$敤浜庡垎缁勮鏁�
+  const groupMap = {};
+  // 閬嶅巻鍘熷鏁版嵁
+  loadData.value.forEach(item => {
+    // 鐢熸垚鍞竴鐨勫垎缁勯敭锛堢粍鍚堜笁涓瓧娈碉級
+    const groupKey = `${item.scanId || ''}-${item.batchNumber || ''}-${item.taskType || ''}`;
+    // 妫�鏌ヨ鍒嗙粍鏄惁宸插瓨鍦�
+    if (groupMap[groupKey]) {
+      // 宸插瓨鍦ㄥ垯鏁伴噺+1
+      groupMap[groupKey].reportCount++;
+    } else {
+      // 涓嶅瓨鍦ㄥ垯鍒涘缓鏂板垎缁�
+      groupMap[groupKey] = {
+        scanId: item.scanId,
+        batchNumber: item.batchNumber,
+        taskType: item.taskType,
+        taskQuantity: item.taskQuantity,
+        reportCount:1
+
+      };
     }
-    errorScanId=findMachine.value.remark.toString();
-    errorInfoFuntion(findMachine.value.remark.toString());
-    errorOpen=true;
-  }else if(findMachine.value.remark.toString()==""&&errorOpen){
-    ElMessageBox.close();
-    errorOpen=false;
+  });
+  console.log(taskingGroupBy.value);
+  // 灏嗗璞¤浆鎹负鏁扮粍
+  taskingGroupBy.value = Object.values(groupMap);
+};
+// 鏂板锛氬畾鏃朵换鍔D锛堢敤浜庢竻闄ゅ畾鏃跺櫒锛�
+const timerId = ref(null);
+/**
+ * 鍗曟鎺ュ彛璇锋眰鍑芥暟
+ * 浣滅敤锛氳皟鐢ㄥ悗绔帴鍙o紝鑾峰彇鏁版嵁鍚庝氦缁� handleMessage 澶勭悊
+ */
+const fetchMachineData = async () => {
+  try {
+    // 浠诲姟鏁版嵁
+    request.post("/deviceInteraction/tasking/findMachineTask",{
+      "id": machineId
+    }).then((res) => { // 鏇挎崲涓轰綘鐨凙PI绔偣
+      if (res.code === 200) {
+        // 鍋囪鍚庣杩斿洖鐨勬暟鎹牸寮忎笌 handleMessage 棰勬湡涓�鑷�
+        const responseData = res.data || {};
+        loadData.value =responseData;
+        groupAndCount();
+      }
+    });
+
+    // 璁惧鏁版嵁
+    request.post("/deviceInteraction/machine/findMachine",{
+      "id": machineId
+    }).then((res) => { // 鏇挎崲涓轰綘鐨凙PI绔偣
+      if (res.code === 200) {
+        // 鍋囪鍚庣杩斿洖鐨勬暟鎹牸寮忎笌 handleMessage 棰勬湡涓�鑷�
+        const responseData = res.data || {};
+        findMachine.value =responseData;
+        if (Object.keys(findMachine.value).length === 0){
+          if(findMachine.value.remark.toString()!=errorScanId&&findMachine.value.remark.toString()!=""&&findMachine.value.remark.toString()!=undefined){
+            //鏈夋暟鎹氨寮圭獥
+            if(errorOpen){
+              ElMessageBox.close();
+            }
+            errorScanId=findMachine.value.remark.toString();
+            errorInfoFuntion(findMachine.value.remark.toString());
+            errorOpen=true;
+          }else if(findMachine.value.remark.toString()==""&&errorOpen){
+            ElMessageBox.close();
+            errorOpen=false;
+          }
+        }
+      }
+    });
+    // 绾夸笅鏁版嵁
+  } catch (err) {
+    console.error('瀹氭椂璇锋眰鍚庣鎺ュ彛澶辫触锛�', err);
   }
-   
 };
-// 瀹氫箟娑堟伅澶勭悊鍑芥暟锛屾洿鏂� receivedData 鍙橀噺
-const handleMessage2 = (data) => {
-  downLineTask.value = data.downLineTask[0];
-  // console.log(data);
+
+/**
+ * 鍚姩瀹氭椂鍣�
+ * @param {number} interval - 瀹氭椂闂撮殧锛堟绉掞紝榛樿500ms锛屼笌鍚庣浠诲姟棰戠巼瀵归綈锛�
+ */
+const startTimer = (interval = 500) => {
+  // 鍏堟竻闄ゅ凡鏈夊畾鏃跺櫒锛堥伩鍏嶉噸澶嶅垱寤猴級
+  if (timerId.value) clearInterval(timerId.value);
+  // 绔嬪嵆鎵ц涓�娆★紙閬垮厤棣栨绛夊緟闂撮殧锛�
+  fetchMachineData();
+  // 鍒涘缓鏂板畾鏃跺櫒
+  timerId.value = setInterval(() => {
+    fetchMachineData();
+  }, interval);
 };
+
+/**
+ * 娓呴櫎瀹氭椂鍣紙閬垮厤鍐呭瓨娉勬紡锛�
+ */
+const clearTimer = () => {
+  if (timerId.value) {
+    clearInterval(timerId.value);
+    timerId.value = null; // 閲嶇疆ID
+  }
+};
+
+// 缁勪欢鍗歌浇鏃舵竻闄ゅ畾鏃跺櫒锛堝叧閿細閬垮厤缁勪欢閿�姣佸悗瀹氭椂鍣ㄤ粛杩愯锛�
 onUnmounted(() => {
-  if (socket) {
-    closeWebSocket(socket);
-  }
-  if (socketDownLineTask) {
-    closeWebSocket(socketDownLineTask);
-  }
-});
-onBeforeUnmount(() => {
-  console.log("鍏抽棴浜�")
-  closeWebSocket();
+  clearTimer();
 });
 
 onMounted(async () => {
-  //浣跨敤WebSocket鏂瑰紡灞曠ず鏁版嵁
-  socket = initializeWebSocket(socketUrl, handleMessage);// 鍒濆鍖� WebSocket锛屽苟浼犻�掓秷鎭鐞嗗嚱鏁�
-  //浣跨敤WebSocket鏂瑰紡灞曠ず鏁版嵁
-  socketDownLineTask = initializeWebSocket(socketDownLineTaskUrl, handleMessage2);// 鍒濆鍖� WebSocket锛屽苟浼犻�掓秷鎭鐞嗗嚱鏁�
+  startTimer(500); // 500ms 闂撮殧锛堝彲鏍规嵁涓氬姟璋冩暣锛屽1000ms锛�
+  // //浣跨敤WebSocket鏂瑰紡灞曠ず鏁版嵁
+  // socket = initializeWebSocket(socketUrl, handleMessage);// 鍒濆鍖� WebSocket锛屽苟浼犻�掓秷鎭鐞嗗嚱鏁�
+  // //浣跨敤WebSocket鏂瑰紡灞曠ず鏁版嵁
+  // socketDownLineTask = initializeWebSocket(socketDownLineTaskUrl, handleMessage2);// 鍒濆鍖� WebSocket锛屽苟浼犻�掓秷鎭鐞嗗嚱鏁�
 });
 //鎶ヨ鎻愮ず
 const errorInfoFuntion = async (info) => {
@@ -362,7 +427,7 @@
 
     <div id="main-body" style="min-height:240px;">
       <!-- 琛ㄦ牸鍐呭 -->
-      <el-table :data="taskinggoruby" stripe
+      <el-table :data="taskingGroupBy" stripe
         :header-cell-style="{ background: '#F2F3F5 ', color: '#1D2129', textAlign: 'center' }"
         :cell-style="{ textAlign: 'center' }">
         <!-- <el-table-column type="selection" min-width="30" /> -->
@@ -383,13 +448,6 @@
         <el-table-column prop="scanId" :label="$t('glassInfo.scanId')" />
         <el-table-column prop="taskQuantity" :label="$t('glassInfo.taskQuantity')" />
         <el-table-column prop="reportCount" :label="$t('glassInfo.reportCount')" />
-        
-        <el-table-column fixed="right" :label="$t('productStock.operate')" align="center" width="270">
-          <template #default="scope">
-            <el-button size="mini" link type="primary" plain @click="damagedTask(scope.row)">{{ $t('functionState.lose')
-              }}</el-button>
-          </template>
-        </el-table-column>
       </el-table>
     </div>
 

--
Gitblit v1.8.0