|
|
@ -55,26 +55,6 @@ function testStatus() { |
|
|
|
} |
|
|
|
} |
|
|
|
onMounted(() => { |
|
|
|
const wsClient = createWebSocket(sharedWsUrl); |
|
|
|
const subscription = wsClient.dataOb.subscribe(data => { |
|
|
|
if (data.type === "cmd") { |
|
|
|
const cmdInfo = peekTxnRecord(data.data.commandId, "task"); |
|
|
|
if (cmdInfo) { |
|
|
|
if ( |
|
|
|
cmdInfo.command === "openDoor" || |
|
|
|
cmdInfo.command === "closeDoor" || |
|
|
|
cmdInfo.command === "startShakeUp" || |
|
|
|
cmdInfo.command === "injectFluid" || |
|
|
|
cmdInfo.command === "moveToActionArea" || |
|
|
|
cmdInfo.command === "moveToHeatArea" |
|
|
|
) { |
|
|
|
setOnGoingStatus("idle"); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
}); |
|
|
|
wsClient.connect(); |
|
|
|
|
|
|
|
const subscription2 = onGoingStatusOb.subscribe(status => { |
|
|
|
if (status === "idle") { |
|
|
|
statusStr.value = "等待指令"; |
|
|
@ -94,7 +74,6 @@ onMounted(() => { |
|
|
|
}); |
|
|
|
|
|
|
|
onUnmounted(() => { |
|
|
|
subscription.unsubscribe(); |
|
|
|
subscription2.unsubscribe(); |
|
|
|
}); |
|
|
|
}); |
|
|
|