joylink/xian-ncc-da-client
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

测试发布

Browse Source
This commit is contained in:
fan 2023-07-31 10:41:50 +08:00
parent 6c9ae09ae8
commit 4a36daf843
1 changed files with 37 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

74
src/drawApp/lineNetApp.ts
View File

@ -107,43 +107,43 @@ export async function loadLineNetDatas(app: GraphicApp) {
pathLineList.forEach((pathLine) => {
pathLine.visible = false;
});
app.enableWsMassaging({
wsUrl: `${getWebsocketUrl()}`,
token: getJwtToken() as string,
});
app.subscribe({
destination: '/queue/lineNet',
messageConverter: (message: Uint8Array) => {
const storage = state.WsLineNetMessage.deserialize(message);
const states: GraphicState[] = [];
storage.offset.forEach((item) => {
states.push(new TrainLineState(item));
});
return states;
},
});
app.subscribe({
destination: '/queue/xian/ncc/alert',
messageHandle: (message: Uint8Array) => {
const storage = alert.NccAlertInfoMessage.deserialize(message);
lineNetStore.setAlarmInfo(storage.messages as []);
},
});
let msgNotify: null | ((props?: QNotifyUpdateOptions | undefined) => void) =
null;
app.on('websocket-connect-state-change', (connected) => {
if (!connected && !msgNotify) {
msgNotify = Notify.create({
type: 'negative',
timeout: 0,
position: 'top-right',
message: '通信链接已断开！',
});
} else if (msgNotify && connected) {
msgNotify();
msgNotify = null;
}
});
// app.enableWsMassaging({
// wsUrl: `${getWebsocketUrl()}`,
// token: getJwtToken() as string,
// });
// app.subscribe({
// destination: '/queue/lineNet',
// messageConverter: (message: Uint8Array) => {
// const storage = state.WsLineNetMessage.deserialize(message);
// const states: GraphicState[] = [];
// storage.offset.forEach((item) => {
// states.push(new TrainLineState(item));
// });
// return states;
// },
// });
// app.subscribe({
// destination: '/queue/xian/ncc/alert',
// messageHandle: (message: Uint8Array) => {
// const storage = alert.NccAlertInfoMessage.deserialize(message);
// lineNetStore.setAlarmInfo(storage.messages as []);
// },
// });
// let msgNotify: null | ((props?: QNotifyUpdateOptions | undefined) => void) =
// null;
// app.on('websocket-connect-state-change', (connected) => {
// if (!connected && !msgNotify) {
// msgNotify = Notify.create({
// type: 'negative',
// timeout: 0,
// position: 'top-right',
// message: '通信链接已断开！',
// });
// } else if (msgNotify && connected) {
// msgNotify();
// msgNotify = null;
// }
// });
} else {
app.loadGraphic([]);
}