From a6b4fd6c0219bb41415cd232daa12ca28eb8add7 Mon Sep 17 00:00:00 2001
From: chenyc <501753378@qq.com>
Date: 星期二, 20 九月 2022 13:19:39 +0800
Subject: [PATCH] up123

---
 src/samples/sockteStomp.ts |   63 +++++++++++++++++--------------
 1 files changed, 34 insertions(+), 29 deletions(-)

diff --git a/src/samples/sockteStomp.ts b/src/samples/sockteStomp.ts
index 90db1c3..cb57715 100644
--- a/src/samples/sockteStomp.ts
+++ b/src/samples/sockteStomp.ts
@@ -35,15 +35,18 @@
             switch(deviceInfo.deviceType){
                 case '读卡器':
                     console.log('读卡器收到消息')
-                    sockteStore().setdkqSockte(
-                        {
-                            deviceName:resultInfo.deviceNumber,
-                            type:"读卡器",
-                            result:resultInfo.result,
-                            resultTime:resultInfo.resultTime,
-                            state:2
-                        }
-                    )
+                    const res=JSON.parse(resultInfo.result)
+                    if(res.clientCode!==null){
+                        sockteStore().setdkqSockte(
+                            {
+                                deviceName:resultInfo.deviceNumber,
+                                type:"读卡器",
+                                result:resultInfo.result,
+                                resultTime:resultInfo.resultTime,
+                                state:2
+                            }
+                        )
+                    }
                     break
                 case "体重秤":
                     console.log(resultInfo,'体重秤')
@@ -51,7 +54,7 @@
                         {
                             deviceName:resultInfo.deviceNumber,
                             type:"体重秤",
-                            result:resultInfo.result,
+                            result:Number(resultInfo.result).toString(),
                             resultTime:resultInfo.resultTime,
                             state:2
                         }
@@ -120,7 +123,8 @@
         deviceCode:resultInfo.deviceCode===null?"":resultInfo.deviceCode,
         hemoCode:resultInfo.hemoCode===null?"":resultInfo.hemoCode,
         pureWeight:resultInfo.pureWeight===null?"":resultInfo.pureWeight,
-        datetime:da  
+        datetime:da,
+        isScheduled:resultInfo.isScheduled
     }
     // 写入vuex里
     patientInfoStore().setpatientInfo(info)
@@ -128,7 +132,6 @@
 
 // 订阅结果事件返回函数
 const  callback = function(message:any) {
-    console.log('接收到数据-----',message.body)
     if (message.body!==undefined) {
         const data=JSON.parse(message.body)
         writeResult(data)
@@ -148,6 +151,7 @@
 }
 const PatientCallback=function(message:any){
     if (message.body) {
+        console.log('00000000000000',message.body)
         const data=JSON.parse(message.body)
         console.log(data,'患者信息读取')
         writePatient(data)
@@ -182,22 +186,23 @@
     // 更新sockte链接状态
     sockteStore().setsockteIsLink(true)
     console.log(sockteStore().isLink)
-    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}));
-
-                } 
-            })
-        }
-    }
+    // sockte订阅服务关闭完全有post 来代替
+    // 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){
+    //                 console.log()
+    //                 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){
@@ -246,4 +251,4 @@
         stompClient.send(`/app/patient/info/set`,{},JSON.stringify(mode))
     }
 }
-export {creatorClient,sendPationCode,sendPationSet}
+export {creatorClient,sendPationCode,sendPationSet,writeResult}

--
Gitblit v1.8.0