Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Create ts302 #826

Open
wants to merge 2 commits into
base: master
Choose a base branch
from
+218 −0
Open

Create ts302 #826

Changes from 1 commit
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
e41101e
Create ts302
Charles-Milesight Sep 18, 2024
be02f0d
Rename ts302 to ts302.js
Charles-Milesight Sep 19, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
218 changes: 218 additions & 0 deletions vendor/milesight-iot/ts302
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,218 @@
/**
* Payload Decoder
*
* Copyright 2024 Milesight IoT
*
* @product TS302
*/
// Chirpstack v4
function decodeUplink(input) {
var decoded = milesightDeviceDecode(input.bytes);
return { data: decoded };
}

// Chirpstack v3
function Decode(fPort, bytes) {
return milesightDeviceDecode(bytes);
}

// The Things Network
function Decoder(bytes, port) {
return milesightDeviceDecode(bytes);
}

function milesight(bytes) {
var decoded = {};

for (var i = 0; i < bytes.length; ) {
var channel_id = bytes[i++];
var channel_type = bytes[i++];
// IPSO VERSION
if (channel_id === 0xff && channel_type === 0x01) {
decoded.ipso_version = readProtocolVersion(bytes[i]);
i += 1;
}
// HARDWARE VERSION
else if (channel_id === 0xff && channel_type === 0x09) {
decoded.hardware_version = readHardwareVersion(bytes.slice(i, i + 2));
i += 2;
}
// FIRMWARE VERSION
else if (channel_id === 0xff && channel_type === 0x0a) {
decoded.firmware_version = readFirmwareVersion(bytes.slice(i, i + 2));
i += 2;
}
// DEVICE STATUS
else if (channel_id === 0xff && channel_type === 0x0b) {
decoded.device_status = 1;
i += 1;
}
// LORAWAN CLASS TYPE
else if (channel_id === 0xff && channel_type === 0x0f) {
decoded.lorawan_class = bytes[i];
i += 1;
}
// SERIAL NUMBER
else if (channel_id === 0xff && channel_type === 0x16) {
decoded.sn = readSerialNumber(bytes.slice(i, i + 8));
i += 8;
}
// BATTERY
else if (channel_id === 0x01 && channel_type === 0x75) {
decoded.battery = bytes[i];
i += 1;
}
// TEMPERATURE (CHANNEL 1)
else if (channel_id === 0x03 && channel_type === 0x67) {
decoded.temperature_chn1 = readInt16LE(bytes.slice(i, i + 2)) / 10;
i += 2;
}
// MAGNET STATUS (CHANNEL 1)
else if (channel_id === 0x03 && channel_type === 0x00) {
decoded.magnet_chn1 = bytes[i];
i += 1;
}
// TEMPERATURE (CHANNEL 2)
else if (channel_id === 0x04 && channel_type === 0x67) {
decoded.temperature_chn2 = readInt16LE(bytes.slice(i, i + 2)) / 10;
i += 2;
}
// MAGNET STATUS (CHANNEL 2)
else if (channel_id === 0x04 && channel_type === 0x00) {
decoded.magnet_chn2 = bytes[i];
i += 1;
}
// TEMPERATURE ALARM (CHANNEL 1)
else if (channel_id === 0x83 && channel_type === 0x67) {
decoded.temperature_chn1 = readInt16LE(bytes.slice(i, i + 2)) / 10;
decoded.temperature_alarm_chn1 = bytes[i + 2];
i += 3;
}
// TEMPERATURE ALARM (CHANNEL 2)
else if (channel_id === 0x84 && channel_type === 0x67) {
decoded.temperature_chn2 = readInt16LE(bytes.slice(i, i + 2)) / 10;
decoded.temperature_alarm_chn2 = bytes[i + 2];
i += 3;
}
// TEMPERATURE ALARM (CHANNEL 1)
else if (channel_id === 0x93 && channel_type === 0xd7) {
decoded.temperature_chn1 = readInt16LE(bytes.slice(i, i + 2)) / 10;
decoded.temperature_change_chn1 = readInt16LE(bytes.slice(i + 2, i + 4)) / 100;
decoded.temperature_alarm_chn1 = bytes[i + 4];
i += 5;
}
// TEMPERATURE ALARM (CHANNEL 2)
else if (channel_id === 0x94 && channel_type === 0xd7) {
decoded.temperature_chn2 = readInt16LE(bytes.slice(i, i + 2)) / 10;
decoded.temperature_change_chn2 = readInt16LE(bytes.slice(i + 2, i + 4)) / 100;
decoded.temperature_alarm_chn2 = bytes[i + 4];
i += 5;
}
// HISTORY
else if (channel_id === 0x20 && channel_type === 0xce) {
var timestamp = readUInt32LE(bytes.slice(i, i + 4));
var mask = bytes[i + 4];
i += 5;

var data = { timestamp: timestamp };
var chn1_event = mask >>> 4;
var chn2_event = mask & 0x0f;
switch (chn1_event) {
case 0x01:
case 0x02:
case 0x03:
case 0x04:
data.temperature_chn1 = readInt16LE(bytes.slice(i, i + 2)) / 10;
data.report_event_chn1 = chn1_event;
break;
case 0x05:
case 0x06:
data.magnet_chn1 = readInt16LE(bytes.slice(i, i + 2));
data.report_event_chn1 = chn1_event;
break;
default:
break;
}
i += 2;

switch (chn2_event) {
case 0x01:
case 0x02:
case 0x03:
case 0x04:
data.temperature_chn2 = readInt16LE(bytes.slice(i, i + 2)) / 10;
data.report_event_chn2 = chn2_event;
break;
case 0x05:
case 0x06:
data.magnet_chn2 = readInt16LE(bytes.slice(i, i + 2));
data.report_event_chn2 = chn2_event;
break;
default:
break;
}
i += 2;

decoded.history = decoded.history || [];
decoded.history.push(data);
} else {
break;
}
}

return decoded;
}

function readUInt16LE(bytes) {
var value = (bytes[1] << 8) + bytes[0];
return value & 0xffff;
}

function readInt16LE(bytes) {
var ref = readUInt16LE(bytes);
return ref > 0x7fff ? ref - 0x10000 : ref;
}

function readUInt32LE(bytes) {
var value = (bytes[3] << 24) + (bytes[2] << 16) + (bytes[1] << 8) + bytes[0];
return (value & 0xffffffff) >>> 0;
}

function readProtocolVersion(bytes) {
var major = (bytes & 0xf0) >> 4;
var minor = bytes & 0x0f;
return "v" + major + "." + minor;
}

function readHardwareVersion(bytes) {
var major = bytes[0] & 0xff;
var minor = (bytes[1] & 0xff) >> 4;
return "v" + major + "." + minor;
}

function readFirmwareVersion(bytes) {
var major = bytes[0] & 0xff;
var minor = bytes[1] & 0xff;
return "v" + major + "." + minor;
}

function readSerialNumber(bytes) {
var temp = [];
for (var idx = 0; idx < bytes.length; idx++) {
temp.push(("0" + (bytes[idx] & 0xff).toString(16)).slice(-2));
}
return temp.join("");
}

function readAlarmType(type) {
switch (type) {
case 0:
return "threshold release";
case 1:
return "threshold";
case 2:
return "mutation";
default:
return "unkown";
}
}