| | |
| | | isErrConnectBackCalled = true |
| | | const pcName= sockteStore().pcName |
| | | console.log("链接成功",stompClient,pcName) |
| | | sockteStore().setsockteIsLink(true) |
| | | // 订阅患者信息服务 |
| | | if(stompClient!==null){ |
| | | // 订阅患者信息事件 |
| | |
| | | devices.forEach(de=>{ |
| | | if(stompClient!==null){ |
| | | stompClient.subscribe(`/queue/${clientCode}/${de.deviceName}/result`,callback) |
| | | // stompClient.subscribe(`/queue/${clientCode}/${de.deviceName}/keepalive`,callbackState) |
| | | 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('60秒之后重连',sockteNum++) |
| | | const socket = new WebSocket('ws://hemobs.icoldchain.cn/broadcast') |