Copy // var msg = {
// "data2" : "29 44 B4 25 33 98 00 20 10 07 7A 0B 00 0020 04 13 35 00 00 00 84 10 13 03 00 00 00 02 5A F1 00 02 FD 17 00 00 02 FD 74 FE 15",
// "data": "3e 44 b425 11111111 10 07 7af8 00 3025 04 13 b70b0000 8410 13 00000000 02 5a 0000 02 FD17 0108 02 fd74 d016",
// "data3": "2944B4253398002010077A4620002004139FB400008410130B000000025AF20002FD17080002FD74E415",
// "data4": "2944B4253398002010077A4620002004139FB400008410130B000000025AF200 02FD17 FF7F 02FD74E415",
// "data5": "2944 B425 3498 0020 1007 7A45 0000 20 0413D67F000084101317000000025AA50002FD17000002FD74E415",
// "data6": "780413600B0000841013CD000000025AB90002FD17000002FD740815"
// }
var decodedMsg = msg;
if (msg && msg.data) {
decodedMsg = main(msg.data)
}
return {
msg: decodedMsg,
metadata: metadata,
msgType: msgType
};
// console.log(decodedMsg)
function main(data) {
var CI_FIELD = '78';
var ADDRESS_INDEX_START = 4;
var ADDRESS_INDEX_END = 7;
var VERSION_INDEX = 8;
var MEDIUM_FIELD = 'Water';
var MANUFACTURER_FIELD = 'IMT';
var VALUE_DIF_VIF = {
waterMeter: '04 13',
reverseWaterMeter: '84 10 13',
flowTemperature: '02 5a',
errorCodes: '02 fd 17',
batteryLifetime: '02 fd 74'
}
var STATUS_AND_EVENT_LIST_FIELD = [
// Don,t remove those following empty fields.
// Those are required since this full list is required for a 16-bit incoming status and event handling data
'', '',
'configMaxWaterTemperature',
'configLimitMinWaterTemperature',
'alarmDry',
'alarmOverFlow',
'alarmReverseFlow',
'alarmBatteryLow',
'alarmNoConsumption',
'alarmOverTemperature',
'alarmHeat',
'alarmFrost',
'alarmLeak',
'alarmBurst',
'alarmAirBubble',
''
]
var ERROR_LIST_FIELD = [
'dry',
'overFlow',
'reverseFlow',
'batteryLow',
'noConsumption',
'overTemperature',
'heat',
'frost',
'leak',
'burst',
'airBubble'
]
if (!String.prototype.includes) {
String.prototype.includes = function(search, start) {
'use strict';
if (typeof start !== 'number') {
start = 0;
}
if (start + search.length > this.length) {
return false;
} else {
return this.indexOf(search, start) !== -1;
}
};
}
function format(value) {
var bytes = value.replaceAll(' ', '').toLowerCase();
var byteArr = []
for (var i = 0; i < bytes.length; i+=2) {
byteArr.push(bytes[i] + "" + bytes[i + 1])
}
return byteArr;
}
function isUnparsed(value) {
return value && !!value.length && value[0] === CI_FIELD;
}
function getBodyPayloadStr(value) {
var payloadStartIndex = isUnparsed(value) ? 1 : 15;
if (value.length > payloadStartIndex) {
return value.slice(payloadStartIndex).join(' ');
}
return '';
}
function getRevHexValue(value, startIndex, endIndex, convertToDecimal, devider) {
endIndex = endIndex || startIndex;
convertToDecimal = convertToDecimal || false;
devider = devider || 1;
var result = Array.isArray(value) && !!value.length && value.slice(startIndex, endIndex + 1).reverse().join('') || null;
if (!!result && convertToDecimal) {
result = parseInt(result, 16) / devider
}
return result;
}
function getAddressAndHeaders(value) {
var res = {};
if (isUnparsed(value)) {
res.ciField = CI_FIELD;
} else {
res = {
secondaryAddress: getRevHexValue(value, ADDRESS_INDEX_START, ADDRESS_INDEX_END),
medium: MEDIUM_FIELD,
length: getRevHexValue(value, 0,0, true),
manufacturer: MANUFACTURER_FIELD,
version: getRevHexValue(value, VERSION_INDEX, VERSION_INDEX, true)
}
}
return res
}
function getDeviceValue(key) {
var result = 1;
if (key === 'waterMeter' || key === 'reverseWaterMeter') {
result = 1000;
} else if (key === 'flowTemperature') {
result = 10;
}
return result;
}
function getValuesByDifVif(valueStr, result) {
result = result || {};
if (!valueStr) {
return result;
}
var newValueStr;
var foundResKey;
for (var key in VALUE_DIF_VIF) {
if ( valueStr.startsWith(VALUE_DIF_VIF[key])) {
foundResKey = key;
break;
}
}
if (!!foundResKey) {
var difVifArr = VALUE_DIF_VIF[foundResKey].split(' ');
if (foundResKey === 'reverseWaterMeter') {
difVifArr[0] = '04'
}
var dataIndexLength = parseInt(difVifArr[0]);
var payloadLength = difVifArr.length + dataIndexLength;
result[foundResKey] = getRevHexValue(
valueStr.split(' '),
payloadLength-dataIndexLength, payloadLength-1, foundResKey !== 'errorCodes', getDeviceValue(foundResKey));
newValueStr = valueStr.split(' ').slice(payloadLength).join(' ');
return getValuesByDifVif(newValueStr, result);
}
newValueStr = valueStr.split(' ').slice(1).join(' ');
return getValuesByDifVif(newValueStr, result);
}
function getDeviceValues(value) {
var bodyPayloadStr = getBodyPayloadStr(value);
return getValuesByDifVif(bodyPayloadStr);
}
function getStatusAndEvents(errorCode) {
var errorCodeInt = parseInt(errorCode, 16);
var errorCodeBin = errorCodeInt.toString(2)
if (errorCodeBin.length < 16 ) {
}
var shortLength = 16 - errorCodeBin.length;
for( var i = 0; i < shortLength; i++) {
errorCodeBin = '0' + errorCodeBin;
}
var result = {
error: !!errorCodeInt,
errors: ''
}
for (var index = 0; index <= STATUS_AND_EVENT_LIST_FIELD.length; index ++) {
var field = STATUS_AND_EVENT_LIST_FIELD[index];
if (!!field) {
result[field] = index<=3 ? parseInt(errorCodeBin[index]) : !!parseInt(errorCodeBin[index]);
var errorVal;
if (!!result[field]) {
for (var j = 0; j < ERROR_LIST_FIELD.length; j++ ) {
if (field.toLowerCase().includes(ERROR_LIST_FIELD[j].toLowerCase())) {
errorVal = ERROR_LIST_FIELD[j];
result.errors += !!errorVal ? !!result.errors ? ', ' + errorVal : errorVal : '';
break;
}
}
}
}
}
return result;
}
function decode(rowValue) {
var formattedValue = format(rowValue);
var addressAndHeaders = getAddressAndHeaders(formattedValue);
var deviceValues = getDeviceValues(formattedValue);
var statusAndEvents = getStatusAndEvents(deviceValues.errorCodes)
return Object.assign({}, addressAndHeaders, deviceValues, statusAndEvents);
}
return decode(data);
}
