EnOcean「STM 550J」を動かしてみよう

// データそのもの
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;

{"id":"*******",
"dbm":-57,"stm550count":1,
"type":"STM550",
"temperature":26.7,
"magnet":0,
"illumination":842,
"humidity":70,
"time":1719542672595}

deviceID = from(bucket: "test2")
  |> range(start:-2h)
  |> filter(fn: (r) => r["_measurement"] == "stm550j" and r["_field"] == "id" and r["_value"] == "0420a6de")
  |> keep(columns: ["_time", "_start", "_stop", "_measurement", "_value"])
  |> rename(columns: {"_value": "deviceID"})

humidityData = from(bucket: "test2")
  |> range(start:-2h)
  |> filter(fn: (r) => r["_measurement"] == "stm550j" and r["_field"] == "humidity")
  |> keep(columns: ["_time", "_start", "_stop", "_measurement", "_value"])
  |> rename(columns: {"_value": "humidity"})

join(
    tables: {deviceID: deviceID, humidityData: humidityData},
    on: ["_time", "_measurement"]
)
  |> keep(columns: ["_time", "humidity", "deviceID"])
  |> yield(name: "humidityData")

deviceID = from(bucket: "test2")
  |> range(start:-2h)
  |> filter(fn: (r) => r["_measurement"] == "stm550j" and r["_field"] == "id" and r["_value"] == "0420a6de")
  |> keep(columns: ["_time", "_start", "_stop", "_measurement", "_value"])
  |> rename(columns: {"_value": "deviceID"})

illuminationData = from(bucket: "test2")
  |> range(start:-2h)
  |> filter(fn: (r) => r["_measurement"] == "stm550j" and r["_field"] == "illumination")
  |> keep(columns: ["_time", "_start", "_stop", "_measurement", "_value"])
  |> rename(columns: {"_value": "illumination"})

join(
    tables: {deviceID: deviceID, illuminationData: illuminationData},
    on: ["_time", "_measurement"]
)
  |> keep(columns: ["_time", "illumination", "deviceID"])
  |> yield(name: "illuminationData")