From 94f16f6a5770c10fce8267e9e851dfc35d8dfbc2 Mon Sep 17 00:00:00 2001
From: chenyc <501753378@qq.com>
Date: 星期五, 26 八月 2022 15:42:47 +0800
Subject: [PATCH] 新增读卡器功能

---
 src/samples/sockteStomp.ts |   55 +++++++++++++++++++++++++++++++++++--------------------
 1 files changed, 35 insertions(+), 20 deletions(-)

diff --git a/src/samples/sockteStomp.ts b/src/samples/sockteStomp.ts
index 01c2590..90db1c3 100644
--- a/src/samples/sockteStomp.ts
+++ b/src/samples/sockteStomp.ts
@@ -30,9 +30,11 @@
             return de.deviceName===resultInfo.deviceNumber
         })
         console.log(deviceInfo,'更具设备number查找到的设备')
+        console.log(resultInfo)
         if(deviceInfo!==undefined){
             switch(deviceInfo.deviceType){
                 case '读卡器':
+                    console.log('读卡器收到消息')
                     sockteStore().setdkqSockte(
                         {
                             deviceName:resultInfo.deviceNumber,
@@ -107,21 +109,21 @@
 
 }
 const writePatient=(resultInfo:any)=>{
+    // 给一个时间变化
+    const da=new Date().toTimeString()  
+    console.log(da)
     const info={
         id:resultInfo.patientInfo===null?0:resultInfo.patientInfo.id,
         code:resultInfo.patientInfo===null?'':resultInfo.patientInfo.code,
-        name:resultInfo.patientInfo===null?0:resultInfo.patientInfo.patientName,
-        patientAvatarIcon:resultInfo.patientInfo===null?0:resultInfo.patientInfo.patientAvatarIcon,
+        name:resultInfo.patientInfo===null?'':resultInfo.patientInfo.patientName,
+        patientAvatarIcon:resultInfo.patientInfo===null?'':resultInfo.patientInfo.patientAvatarIcon,
         deviceCode:resultInfo.deviceCode===null?"":resultInfo.deviceCode,
         hemoCode:resultInfo.hemoCode===null?"":resultInfo.hemoCode,
-        pureWeight:resultInfo.pureWeight===null?"":resultInfo.pureWeight
+        pureWeight:resultInfo.pureWeight===null?"":resultInfo.pureWeight,
+        datetime:da  
     }
     // 写入vuex里
     patientInfoStore().setpatientInfo(info)
-    console.log('播放声音')
-    // sound.play("https://dhcdn.leon056.com/hemo/autoselfsign/step2.mp3")
-    
-
 }
 
 // 订阅结果事件返回函数
@@ -161,9 +163,12 @@
         
     }
 }
+var isErrConnectBackCalled = false;
 const connectCallback=function(){
+    isErrConnectBackCalled = true
     const pcName= sockteStore().pcName
     console.log("链接成功",stompClient,pcName)
+    sockteStore().setsockteIsLink(true)
     // 订阅患者信息服务
     if(stompClient!==null){
         // 订阅患者信息事件
@@ -177,26 +182,36 @@
     // 更新sockte链接状态
     sockteStore().setsockteIsLink(true)
     console.log(sockteStore().isLink)
-    if(devices!==undefined&&devices.length>0){
-        devices.forEach(de=>{
-            if(stompClient!==null){
-                stompClient.subscribe(`/queue/${clientCode}/${de.deviceName}/result`,callback)
-                // stompClient.subscribe(`/queue/${clientCode}/${de.deviceName}/keepalive`,callbackState)
-                stompClient.send(`/app/device/request/${clientCode}/${de.deviceName}`, {}, JSON.stringify({"deviceNumber":de.deviceName}));
+    if(devices!==undefined &&devices!=null&&devices.length>0){
+        // 更新sockte链接状态
+        sockteStore().setsockteIsLink(true) 
+        console.log(sockteStore().isLink)
+        console.log(devices)
+        if(devices!==undefined&&devices!=null &&devices!=null &&devices.length>0){
+            devices.forEach(de=>{
+                if(stompClient!==null){
+                    stompClient.subscribe(`/queue/${clientCode}/${de.deviceName}/result`,callback)
+                    stompClient.subscribe(`/queue/${clientCode}/${de.deviceName}/keepalive`,callbackState)
+                    stompClient.send(`/app/device/request/${clientCode}/${de.deviceName}`, {}, JSON.stringify({"deviceNumber":de.deviceName}));
 
-            } 
-        })
+                } 
+            })
+        }
     }
 }
+
 const error_callback=function(error:any){
     console.log('链接错误',error);
+    sockteStore().setsockteIsLink(false)
     setTimeout(()=>{
-        console.log('10秒之后重连',sockteNum++)
+        console.log('60秒之后重连',sockteNum++) 
         const socket = new WebSocket('ws://hemobs.icoldchain.cn/broadcast')
-        stompClient = Stomp.over(socket)
-        stompClient.connect({}, connectCallback,error_callback)
-
-    },10000)
+        stompClient?.disconnect(()=>{
+            console.log("disconnected!");
+            stompClient = Stomp.over(socket)
+            stompClient.connect({}, connectCallback,error_callback)
+        },{})
+    },60000)
 }
 // 创建客户端链接
 const creatorClient=(devices2:any,clientCode2:any)=>{

--
Gitblit v1.8.0