joylink/rts-sim-testing-client
6
0
Fork 0
Code Issues 2 Pull Requests Actions Packages Projects Releases Wiki Activity

恢复测试内容

Browse Source
This commit is contained in:
fan 2023-08-01 10:30:19 +08:00
parent a12929f048
commit f9c8594253
1 changed files with 84 additions and 84 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

168
src/drawApp/lineApp.ts
View File

@ -2,7 +2,7 @@ import {
GraphicApp,
GraphicData,
GraphicState,
// ClientEngine,
ClientEngine,
} from 'src/jl-graphic';
import { TrainState } from './graphics/TrainInteraction';
import { Train, TrainTemplate } from 'src/graphics/train/Train';
@ -308,91 +308,91 @@ export async function loadLineDatas(app: GraphicApp) {
}
});
// app.enableWsMassaging({
// engine: ClientEngine.Centrifugo,
// wsUrl: `${getWebsocketUrl()}`,
// token: getOnlyToken() as string,
// });
app.enableWsMassaging({
engine: ClientEngine.Centrifugo,
wsUrl: `${getWebsocketUrl()}`,
token: getOnlyToken() as string,
});
// app.subscribe({
// // destination: `/simulation/${simulationId}/devices/status`,
// destination: `simulation-${simulationId}-devices-status`,
// messageConverter: (message: Uint8Array) => {
// const states: GraphicState[] = [];
// const storage = state.PushedDevicesStatus.deserialize(message);
// // console.log(storage, 'storage');
// if (storage.all) {
// storage.allStatus.sectionState.forEach((item) => {
// if (state.SectionType[item.type] == 'Axle') {
// //计轴区段
// // states.push(new AxleCountingState(item));
// } else if (state.SectionType[item.type] == 'Logic') {
// // 逻辑区段
// // states.push(new LogicSectionState(item));
// } else if (state.SectionType[item.type] == 'Physic') {
// // 物理区段
// // states.push(new SectionState(item));
// }
// });
// storage.allStatus.switchState.forEach((item) => {
// // 道岔
// states.push(new TurnoutStates(item));
// });
// storage.allStatus.trainState.forEach((item) => {
// // 列车
// states.push(new TrainState(item));
// });
// } else {
// storage.varStatus.updatedSection.forEach((item) => {
// if (state.SectionType[item.type] == 'Axle') {
// //计轴区段
// // states.push(new AxleCountingState(item));
// } else if (state.SectionType[item.type] == 'Logic') {
// // 逻辑区段
// // states.push(new LogicSectionState(item));
// } else if (state.SectionType[item.type] == 'Physic') {
// // 物理区段
// // states.push(new SectionState(item));
// }
// });
// storage.varStatus.updatedSwitch.forEach((item) => {
// // 道岔
// states.push(new TurnoutStates(item));
// });
// storage.varStatus.updatedTrain.forEach((item) => {
// // 列车
// states.push(new TrainState(item));
// });
// storage.varStatus.removedTrainId.forEach((item) => {
// // 移除列车
// const train = app.queryStore.queryByCodeAndType(item, Train.Type);
// if (train) {
// app.deleteGraphics(train);
// }
// });
// }
// if (states && states.length > 0) {
// lineStore.setSocketStates(states);
// }
// return states;
// },
// });
app.subscribe({
// destination: `/simulation/${simulationId}/devices/status`,
destination: `simulation-${simulationId}-devices-status`,
messageConverter: (message: Uint8Array) => {
const states: GraphicState[] = [];
const storage = state.PushedDevicesStatus.deserialize(message);
// console.log(storage, 'storage');
if (storage.all) {
storage.allStatus.sectionState.forEach((item) => {
if (state.SectionType[item.type] == 'Axle') {
//计轴区段
// states.push(new AxleCountingState(item));
} else if (state.SectionType[item.type] == 'Logic') {
// 逻辑区段
// states.push(new LogicSectionState(item));
} else if (state.SectionType[item.type] == 'Physic') {
// 物理区段
// states.push(new SectionState(item));
}
});
storage.allStatus.switchState.forEach((item) => {
// 道岔
states.push(new TurnoutStates(item));
});
storage.allStatus.trainState.forEach((item) => {
// 列车
states.push(new TrainState(item));
});
} else {
storage.varStatus.updatedSection.forEach((item) => {
if (state.SectionType[item.type] == 'Axle') {
//计轴区段
// states.push(new AxleCountingState(item));
} else if (state.SectionType[item.type] == 'Logic') {
// 逻辑区段
// states.push(new LogicSectionState(item));
} else if (state.SectionType[item.type] == 'Physic') {
// 物理区段
// states.push(new SectionState(item));
}
});
storage.varStatus.updatedSwitch.forEach((item) => {
// 道岔
states.push(new TurnoutStates(item));
});
storage.varStatus.updatedTrain.forEach((item) => {
// 列车
states.push(new TrainState(item));
});
storage.varStatus.removedTrainId.forEach((item) => {
// 移除列车
const train = app.queryStore.queryByCodeAndType(item, Train.Type);
if (train) {
app.deleteGraphics(train);
}
});
}
if (states && states.length > 0) {
lineStore.setSocketStates(states);
}
return states;
},
});
// 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;
// }
// });
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([]);
}