注释websocket代码提供给测试人员进行测试
This commit is contained in:
@@ -121,47 +121,39 @@ export class MainComponent implements OnInit {
|
|||||||
visibleCount: number = 0;
|
visibleCount: number = 0;
|
||||||
scrollTop: number = 0;
|
scrollTop: number = 0;
|
||||||
|
|
||||||
data = [
|
|
||||||
'Racing car sprays burning fuel into crowd.',
|
|
||||||
'Japanese princess to wed commoner.',
|
|
||||||
'Australian walks 100km after outback crash.',
|
|
||||||
'Man charged over missing wedding girl.',
|
|
||||||
'Los Angeles battles huge wildfires.'
|
|
||||||
];
|
|
||||||
|
|
||||||
ngOnInit() {
|
ngOnInit() {
|
||||||
window.onresize = function () {
|
window.onresize = function () {
|
||||||
this.calcVisibleCount();
|
this.calcVisibleCount();
|
||||||
}.bind(this)
|
}.bind(this)
|
||||||
|
|
||||||
//订阅航班更新
|
//订阅航班更新
|
||||||
this.websocketService.dynamicsMessage().subscribe(
|
// this.websocketService.dynamicsMessage().subscribe(
|
||||||
event => {
|
// event => {
|
||||||
setInterval(() => {
|
// setInterval(() => {
|
||||||
let msg = { "topic": "heart-beat", "message": "" };
|
// let msg = { "topic": "heart-beat", "message": "" };
|
||||||
this.websocketService.websocket.send(JSON.stringify(msg));
|
// this.websocketService.websocket.send(JSON.stringify(msg));
|
||||||
}, 30000);
|
// }, 30000);
|
||||||
let data = JSON.parse(event as string);
|
// let data = JSON.parse(event as string);
|
||||||
if (data.topic === 'schd') {
|
// if (data.topic === 'schd') {
|
||||||
let message = JSON.parse(data.message);
|
// let message = JSON.parse(data.message);
|
||||||
// console.log(message);
|
// // console.log(message);
|
||||||
//是否可以开始处理动态消息
|
// //是否可以开始处理动态消息
|
||||||
if (this.canHandleDynamicMessage) {
|
// if (this.canHandleDynamicMessage) {
|
||||||
this.dynamicMessageHandle(message);
|
// this.dynamicMessageHandle(message);
|
||||||
} else {
|
// } else {
|
||||||
this.dynamicMessageArray.push(message);
|
// this.dynamicMessageArray.push(message);
|
||||||
}
|
// }
|
||||||
} else if (data.topic === 'msg') {
|
// } else if (data.topic === 'msg') {
|
||||||
let message = JSON.parse(data.message);
|
// let message = JSON.parse(data.message);
|
||||||
// console.log(message);
|
// // console.log(message);
|
||||||
if (this.canHandleDynamicAlert) {
|
// if (this.canHandleDynamicAlert) {
|
||||||
this.dynamicAlertHandle(message);
|
// this.dynamicAlertHandle(message);
|
||||||
} else {
|
// } else {
|
||||||
this.dynamicAlertArray.push(message);
|
// this.dynamicAlertArray.push(message);
|
||||||
}
|
// }
|
||||||
}
|
// }
|
||||||
}
|
// }
|
||||||
)
|
// )
|
||||||
|
|
||||||
this.httpCilent.get('/adminapi/settings/uisettings').subscribe(
|
this.httpCilent.get('/adminapi/settings/uisettings').subscribe(
|
||||||
data => {
|
data => {
|
||||||
|
|||||||
Reference in New Issue
Block a user