telemetryJS/main.js at main · ggoulartm/telemetryJS · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
client = new Paho.MQTT.Client(brokerIp, brokerPort, username);

let interface = {};

window.onload = () => {
  interface = {
    ...interface,
    vGraph: new Chart(
      document.getElementById("vPack").getContext("2d"),
      defaultVGraphOptions
    ),
    cGraph: new Chart(
      document.getElementById("cPack").getContext("2d"),
      defaultCGraphOptions
    ),
    tGraph: new Chart(
      document.getElementById("tPack").getContext("2d"),
      defaultTGraphOptions
    ),
    warningList: warningIdList.reduce((accumulator, currentId) => {
      accumulator[currentId] = document.getElementById(currentId);
      return accumulator;
    }, {}),
    infoList: infoIdList.reduce((accumulator, currentId) => {
      accumulator[currentId] = document.getElementById(currentId);
      return accumulator;
    }, {}),
  };

  client.connect({
    useSSL: true,
    timeout: 100,
    userName: username,
    password: password,
    onSuccess: () => {
      console.log("MQTT Connected Succesfully");
      client.subscribe("test");
      client.subscribe("GPS_Topic");
      client.subscribe("0x186455F4");
      client.subscribe("0x186555F4");
      client.subscribe("0x186655F4");
      client.subscribe("0x186755F4");
    },
  });
};

client.onConnectionLost = (responseObject) => {
  if (responseObject.errorCode !== 0) {
    console.log("onConnectionLost:" + responseObject.errorMessage);
  }
};

client.onMessageArrived = (message) => {
  const topic = message.destinationName;
  const data = message.payloadString.split(";");
  console.log(topic);
  console.log(data);
  const { overTemperature, overCurrent, CHG, DSG, overVoltage, underVoltage } =
    interface.warningList;

  const { SoC, cPackInfo, vPackInfo, tPackInfo, power } = interface.infoList;

  const { red, green } = warningColors;

  switch (topic) {
    case GPS_Topic:
      const payload = JSON.parse(data)
      console.log(payload.location.coordinates)
      location.lat = parseFloat(payload.location.coordinates[1])
      location.lng = parseFloat(payload.location.coordinates[0])
      window.placeMarker(location, window.marker)
      break;
    case POWER_Topic:
      boatBattery.power = Number(data[3]);
      power.innerHTML = `${boatBattery.power} W`;
      overTemperature.style.backgroundColor =
        data[2][0] == "1" || data[2][1] == "1" ? red : green;
      overCurrent.style.backgroundColor =
        data[2][2] == "1" || data[2][3] == "1" ? red : green;
      CHG.style.backgroundColor = data[2][4] == "1" ? red : green;
      DSG.style.backgroundColor = data[2][5] == "1" ? red : green;
      overVoltage.style.backgroundColor = data[2][6] == "1" ? red : green;
      underVoltage.style.backgroundColor = data[2][7] == "1" ? red : green;
      break;

    case VOLTAGE_Topic:
      boatBattery.SoC = parseInt(data[3]);
      SoC.innerHTML = `${boatBattery.SoC} %`;

      boatBattery.cPack = (parseInt(data[2]) + parseInt(data[1])) / 2;
      cPackInfo.innerHTML = `${boatBattery.cPack / 10} A`;
      updateCGraph();

      boatBattery.vPack = parseInt(data[0]);
      vPackInfo.innerHTML = `${boatBattery.vPack / 10} V`;
      updateVGraph();

      break;

    case TEMPERATURE_Topic1:
      boatBattery.cellTemp.cell4 = parseInt(data[3]);
      boatBattery.cellTemp.cell3 = parseInt(data[2]);
      boatBattery.cellTemp.cell2 = parseInt(data[1]);
      boatBattery.cellTemp.cell1 = parseInt(data[0]);
      boatBattery.tPack =
        Object.values(boatBattery.cellTemp).reduce((a, b) => a + b, 0) /
        Object.values(boatBattery.cellTemp).filter((val) => val !== 0)
          .length || 0;
      tPackInfo.innerHTML = `${boatBattery.tPack / 10} °C`;
      break;

    case TEMPERATURE_Topic2:
      boatBattery.cellTemp.cell8 = parseInt(data[3]);
      boatBattery.cellTemp.cell7 = parseInt(data[2]);
      boatBattery.cellTemp.cell6 = parseInt(data[1]);
      boatBattery.cellTemp.cell5 = parseInt(data[0]);
      boatBattery.tPack =
        Object.values(boatBattery.cellTemp).reduce((a, b) => a + b, 0) /
        Object.values(boatBattery.cellTemp).filter((val) => val !== 0)
          .length || 0;
      tPackInfo.innerHTML = `${boatBattery.tPack / 10} °C`;
      updateTGraph();
      break;

    default:
      break;
  }
};