parent
f09fe81a91
commit
6242bc5ba6
@ -1,7 +1,7 @@
|
|||||||
import { GraphicApp, GraphicData, GraphicState } from 'src/jl-graphic';
|
import { GraphicApp, GraphicData, GraphicState } from 'src/jl-graphic';
|
||||||
import { getPublishLineNet } from 'src/api/PublishApi';
|
import { getPublishLineNet } from 'src/api/PublishApi';
|
||||||
import { graphicData } from 'src/protos/stationLayoutGraphics';
|
import { graphicData } from 'src/protos/stationLayoutGraphics';
|
||||||
import { state } from 'src/protos/ws_message';
|
// import { state } from 'src/protos/ws_message';
|
||||||
|
|
||||||
import { RunLine, RunLineTemplate } from 'src/graphics/runLine/RunLine';
|
import { RunLine, RunLineTemplate } from 'src/graphics/runLine/RunLine';
|
||||||
import {
|
import {
|
||||||
@ -25,10 +25,10 @@ import { RectData } from './graphics/RectInteraction';
|
|||||||
|
|
||||||
import { useLineNetStore } from 'src/stores/line-net-store';
|
import { useLineNetStore } from 'src/stores/line-net-store';
|
||||||
import { toUint8Array } from 'js-base64';
|
import { toUint8Array } from 'js-base64';
|
||||||
import { getWebsocketUrl } from 'src/configs/UrlManage';
|
// import { getWebsocketUrl } from 'src/configs/UrlManage';
|
||||||
import { getJwtToken } from 'src/configs/TokenManage';
|
// import { getJwtToken } from 'src/configs/TokenManage';
|
||||||
import { alert } from 'src/protos/alertInfo';
|
// import { alert } from 'src/protos/alertInfo';
|
||||||
import { QNotifyUpdateOptions, Notify } from 'quasar';
|
// import { QNotifyUpdateOptions, Notify } from 'quasar';
|
||||||
|
|
||||||
let lineNetApp: GraphicApp | null = null;
|
let lineNetApp: GraphicApp | null = null;
|
||||||
|
|
||||||
@ -107,43 +107,43 @@ export async function loadLineNetDatas(app: GraphicApp) {
|
|||||||
pathLineList.forEach((pathLine) => {
|
pathLineList.forEach((pathLine) => {
|
||||||
pathLine.visible = false;
|
pathLine.visible = false;
|
||||||
});
|
});
|
||||||
app.enableWsMassaging({
|
// app.enableWsMassaging({
|
||||||
wsUrl: `${getWebsocketUrl()}`,
|
// wsUrl: `${getWebsocketUrl()}`,
|
||||||
token: getJwtToken() as string,
|
// token: getJwtToken() as string,
|
||||||
});
|
// });
|
||||||
app.subscribe({
|
// app.subscribe({
|
||||||
destination: '/queue/lineNet',
|
// destination: '/queue/lineNet',
|
||||||
messageConverter: (message: Uint8Array) => {
|
// messageConverter: (message: Uint8Array) => {
|
||||||
const storage = state.WsLineNetMessage.deserialize(message);
|
// const storage = state.WsLineNetMessage.deserialize(message);
|
||||||
const states: GraphicState[] = [];
|
// const states: GraphicState[] = [];
|
||||||
storage.offset.forEach((item) => {
|
// storage.offset.forEach((item) => {
|
||||||
states.push(new TrainLineState(item));
|
// states.push(new TrainLineState(item));
|
||||||
});
|
// });
|
||||||
return states;
|
// return states;
|
||||||
},
|
// },
|
||||||
});
|
// });
|
||||||
app.subscribe({
|
// app.subscribe({
|
||||||
destination: '/queue/xian/ncc/alert',
|
// destination: '/queue/xian/ncc/alert',
|
||||||
messageHandle: (message: Uint8Array) => {
|
// messageHandle: (message: Uint8Array) => {
|
||||||
const storage = alert.NccAlertInfoMessage.deserialize(message);
|
// const storage = alert.NccAlertInfoMessage.deserialize(message);
|
||||||
lineNetStore.setAlarmInfo(storage.messages as []);
|
// lineNetStore.setAlarmInfo(storage.messages as []);
|
||||||
},
|
// },
|
||||||
});
|
// });
|
||||||
let msgNotify: null | ((props?: QNotifyUpdateOptions | undefined) => void) =
|
// let msgNotify: null | ((props?: QNotifyUpdateOptions | undefined) => void) =
|
||||||
null;
|
// null;
|
||||||
app.on('websocket-connect-state-change', (connected) => {
|
// app.on('websocket-connect-state-change', (connected) => {
|
||||||
if (!connected && !msgNotify) {
|
// if (!connected && !msgNotify) {
|
||||||
msgNotify = Notify.create({
|
// msgNotify = Notify.create({
|
||||||
type: 'negative',
|
// type: 'negative',
|
||||||
timeout: 0,
|
// timeout: 0,
|
||||||
position: 'top-right',
|
// position: 'top-right',
|
||||||
message: '通信链接已断开!',
|
// message: '通信链接已断开!',
|
||||||
});
|
// });
|
||||||
} else if (msgNotify && connected) {
|
// } else if (msgNotify && connected) {
|
||||||
msgNotify();
|
// msgNotify();
|
||||||
msgNotify = null;
|
// msgNotify = null;
|
||||||
}
|
// }
|
||||||
});
|
// });
|
||||||
} else {
|
} else {
|
||||||
app.loadGraphic([]);
|
app.loadGraphic([]);
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user