EnOcean温湿度照度センサのデータをGrafanaで可視化させる(6日目)

// データそのもの
var buf = msg.payload;
// データのコピー（検証用）
var rawData = buf.slice(0, buf.length);
// 取り出しやすいようにhex変換したもの
var rawByte = buf.toString("hex");
// ESP3仕様のdataLengthを拾う
var dataLength = 255 * buf + buf;
// ESP3仕様のoptionalLengthを拾う
var optionalLength = buf;
// packetType
var packetType = buf;
// headerCRC
var headerCRC = buf[5];
// dataLengthに基づいたデータ部分の切り出し
var rawDataByte = buf.slice(7, 7 + dataLength + 2);

var id = rawDataByte.slice(0, 4).toString("hex");

// payloadに格納
msg.payload = {
    rawData: rawData,
    rawByte: rawByte,
    dataLength: dataLength,
    optionalLength: optionalLength,
    packetType: packetType,
    headerCRC: headerCRC,
    rawDataByte: rawDataByte,
    ID: id
}

return msg;

const rawData = msg.payload.rawDataByte;

// Extract basic information
msg.id = rawData.slice(0, 4).toString('hex');
msg.dbm = rawData[15] * -1;
msg.stm550count = 1;
msg.type = 'STM550';

// Extract data bytes
const d0 = 4;
const data = Array.from({ length: 9 }, (_, i) => rawData[d0 + i].toString(2).padStart(8, '0'));

msg.data = {
    data_8: data[0],
    data_7: data,
    data_6: data,
    data_5: data,
    data_4: data,
    data_3: data[5],
    data_2: data[6],
    data_1: data[7],
    data_0: data[8]
};

// Calculate temperature
const temp = data[0] + data.slice(0, 2);
msg.temperature = Math.round((parseInt(temp, 2) / 10 - 40) * 100) / 100;

// Calculate magnet
msg.magnet = parseInt(data[8].slice(3, 4), 2);

// Calculate illumination
const illumination = data.slice(2) + data + data.slice(0, 3);
msg.illumination = parseInt(illumination, 2);

const IllValue = msg.illumination;
let IllmaxValue = global.get('maxIll2') || 0;
let IllminValue = global.get('minIll2') || 1000;

if (IllmaxValue < IllValue) {
    IllmaxValue = IllValue;
    global.set('maxIll2', IllmaxValue);
}
if (IllminValue > IllValue) {
    IllminValue = IllValue;
    global.set('minIll2', IllminValue);
}

global.set('Ill', IllValue);

// Calculate humidity
const humidity = data.slice(2, 6) + data.slice(0, 2);
msg.humidity = Math.round(parseInt(humidity, 2) * 20) / 10;

// Aggregate data
msg.payload = {
    id: msg.id,
    dbm: msg.dbm,
    stm550count: msg.stm550count,
    type: msg.type,
    temperature: msg.temperature,
    magnet: msg.magnet,
    illumination: msg.illumination,
    humidity: msg.humidity,
    time: Date.now()
};

return msg;

from(bucket: "mqtt")
  |> range(start: -30d) // 過去30日のデータを取得
  |> filter(fn: (r) => r._measurement == "mqtt_influx")
  |> filter(fn: (r) => r._field == "temperature" or r._field == "illumination" or r._field == "humidity" or r._field == "dbm" or r._field == "magnet")
  |> limit(n: 100) // 直近の100件を表示