map.component.ts 3.27 KB
import {Component, OnInit} from '@angular/core';
import * as L from 'leaflet';
import {CircleMarker} from 'leaflet';
import {Vessels} from '../../model/vessels';
import {VesselsService} from '../../service/vessels.service';
import {Message} from '../../model/message';
import {SelectedVesselService} from '../../service/selected-vessel.service';
import {Vessel} from '../../model/vessel';

@Component({
  selector: 'app-map',
  templateUrl: './map.component.html',
  styleUrls: ['./map.component.scss']
})
export class MapComponent implements OnInit {
  vessels: Vessels;
  selectedVessel: Vessel;
  public map: L.Map;
  renderer = L.canvas({padding: 0.5});
  circleMarkers: Map<number, Array<CircleMarker>> = new Map<number, Array<CircleMarker>>();
  highlightedMarkerId: number;

  constructor(private vesselsService: VesselsService, private selectedVesselService: SelectedVesselService) {
  }

  ngOnInit(): void {
    this.initMap();
    this.connectVesselObservable();
    this.connectSelectVesselObservable();
  }

  connectVesselObservable(): void {
    this.vesselsService.currentVessels.subscribe(vessels => {
      this.vessels = vessels;
      this.updateMap();
    });
  }

  connectSelectVesselObservable(): void {
    this.selectedVesselService.currentVessel.subscribe(vessels => {
      this.selectedVessel = vessels;
      const mmsi = this.selectedVessel.getMMSI();
      if (mmsi !== undefined) {
        this.highlightMarker(Number(this.selectedVessel.getMMSI()));
      }
    });
  }

  initMap(): void {
    this.map = L.map('map').setView([0, 0], 1);
    L.tileLayer('http://{s}.tile.osm.org/{z}/{x}/{y}.png', {
      attribution: 'map',
    }).addTo(this.map);
  }

  addCircleMarker(message: Message, color: string): void {
    let circleMarker;
    if (message.mmsi === this.selectedVessel.getMMSI()) {
      circleMarker = L.circleMarker([+message.latitude, +message.longitude],
        {
          renderer: this.renderer,
          radius: 4,
          color: '#ff0000',
        }).addTo(this.map).bringToFront();
    } else {
      circleMarker = L.circleMarker([+message.latitude, +message.longitude],
        {
          renderer: this.renderer,
          radius: 1,
          color
        }).addTo(this.map);
    }
    if (!this.circleMarkers.has(Number(message.mmsi))){
      this.circleMarkers.set(Number(message.mmsi), new Array<CircleMarker>());
    }
    this.circleMarkers.get(Number(message.mmsi)).push(circleMarker);
  }

  highlightMarker(mmsi: number): void {
    if (this.highlightedMarkerId !== undefined) {
      const color = this.vessels.vessels.get(this.highlightedMarkerId).getColor();
      this.circleMarkers.get(this.highlightedMarkerId).forEach(value => value.setStyle({color, fillColor: color}));
      this.circleMarkers.get(this.highlightedMarkerId).forEach(value => value.setRadius(1));

    }
    this.highlightedMarkerId = mmsi;
    this.circleMarkers.get(mmsi).forEach(value => value.setStyle({fillColor: '#ff0000', color: '#ff0000', fillOpacity: 1}));
    this.circleMarkers.get(mmsi).forEach(value => value.setRadius(4));
  }

  updateMap(): void {
    this.circleMarkers.clear();
    this.vessels.vessels.forEach(((vessel, key) => {
      const color = vessel.getColor();
      vessel.messages.forEach((message) => {
        this.addCircleMarker(message, color);
      });
    }));
  }

}