MZ
это я в курсе и протокол знаю. Но мне бы как-то лимиты установить без пульта, чтобы он показывал позицию.
Size: a a a
2021 November 15
MZ
не. позиция там от 0 до 100. А 255 - это границы не установлены
MZ
просто в мануалах что я нагуглил это делается с пульта. А пульта пока нет 8(
MZ
так вот без пульта что-то не получается. Видимо я чего-то не понимаю в китайской логике.
MZ
при включении он границы не проверяет
MZ
может прописать что-то нужно в настройки.
MZ
в этом и вопрос - какую? :)
MZ
да было бы не плохо
AD
var CurtsCommands = new Array(
{ Name: 'cmdSetPercent', bufSize: 8, cmdFunc: 0x03, cmdAddr: 0x04, Description: 'Set percent to open'},
{ Name: 'cmdReadPercent', bufSize: 8, cmdFunc: 0x01, cmdAddr: 0x02, Description: 'Read percent to open'},
{ Name: 'cmdReadMotor', bufSize: 8, cmdFunc: 0x01, cmdAddr: 0x05, Description: 'Read motor state'},
{ Name: 'cmdPathReset', bufSize: 7, cmdFunc: 0x03, cmdAddr: 0x07, Description: 'Path reset'},
);
var Curts = new Array(
{ Name: 'Hall', Address: 0x0210, Description: 'Зал'},
{ Name: 'Bedroom', Address: 0x0209, Description: 'Спальня'}
);
Curts.forEach ( element => {
createState('javascript.0.States.Curtains.' + element.Name + '_state', 0,{name: element.Description + ': cостояние карниза', type: 'number'});
createState('javascript.0.States.Curtains.' + element.Name + '_reset', false,{name: element.Description + ': команда сброса положения карниза', type: 'boolean'});
})
var ffAlert = false;
on({id: 'javascript.0.States.Curtains.Hall_state', change: 'ne'}, function (obj) {
if (obj.state.val < 101) {
if(COMGW_debug) log('** Hall curtains * -> Set Percent to ' + obj.state.val, "info");
setState('javascript.0.States.Curtains.Hall_state', obj.state.val, false);
CurtainSend('Hall', 'cmdSetPercent', obj.state.val);
} else {
ffAlert = true;
setTimeout(function() {
ffAlert = false;
}, 120000);
setState('javascript.0.States.Curtains.Hall_manual', false, true);
setStateDelayed('javascript.0.States.Curtains.Hall_state', 100, true, 1000, false);
setStateDelayed('javascript.0.States.Curtains.Hall_state', 0, true, 30000, false);
setStateDelayed('javascript.0.States.Curtains.Hall_manual', true, true, 60000);
}
});
on({id: 'javascript.0.States.Curtains.Bedroom_state', change: 'ne'}, function (obj) {
if (obj.state.val < 101) {
if(COMGW_debug) log('** Bedroom curtains * -> Set Percent to ' + obj.state.val, "info");
setState('javascript.0.States.Curtains.Bedroom_state', obj.state.val, false);
CurtainSend('Bedroom', 'cmdSetPercent', obj.state.val);
} else {
ffAlert = true;
setTimeout(function() {
ffAlert = false;
}, 120000);
setState('javascript.0.States.Curtains.Bedroom_manual', false, true);
setStateDelayed('javascript.0.States.Curtains.Bedroom_state', 100, true, 1000, false);
setStateDelayed('javascript.0.States.Curtains.Bedroom_state', 0, true, 30000, false);
setStateDelayed('javascript.0.States.Curtains.Bedroom_manual', true, true, 60000);
}
});
on({id: 'javascript.0.States.Curtains.Hall_reset', change: 'gt'}, function () { //сброс концевых настроек зал
sendTo('telegram.0', 'Сделан ручной сброс концевых настроек карниза в зале.');
if(COMGW_debug) log('** Curtains * -> Hall Reset', "info");
CurtainSend('Hall', 'cmdPathReset');
setState('javascript.0.States.Curtains.Hall_reset', false, false);
setState('javascript.0.States.Curtains.Hall_state', 255, true);
});
on({id: 'javascript.0.States.Curtains.Bedroom_reset', change: 'gt'}, function () { //сброс концевых настроек спалььня
sendTo('telegram.0', 'Сделан ручной сброс концевых настроек карниза в спальне.');
if(COMGW_debug) log('** Curtains * -> Bedroom Reset', "info");
CurtainSend('Bedroom', 'cmdPathReset');
setState('javascript.0.States.Curtains.Bedroom_reset', false, false);
setState('javascript.0.States.Curtains.Bedroom_state', 255, true);
});
const COMGWIP = '192.168.118.140'; // IP адрес шлюза Eth-485 IP135 504
const COMGWPort = 509; // Порт 3 шлюза Eth-485
// Состояние подключения к Eth/RSxxx адаптеру
var COMGW_conn = "javascript.0.States.Curtains.Connection";
// Включить дополнительное логгирование
var COMGW_debug = false;
// Создаем стейты
createState(COMGW_conn, false, {name: "Подключение к конвертеру штор 485/Eth", states: "false:Offline;true:Online", type: "boolean"});
AD
var net = require('net'); // Подгружаем модуль JS Net
var client = new net.Socket(); // Общий сокет для всего скрипта
// *******************************
// Вспомогательные функции
// *******************************
// Печатаем в HEX
var toHexString = function (byteArray) {
return Array.from(byteArray, function (byte) {
return ('0' + (byte & 0xFF).toString(16)).slice(-2);
}).join(' ');
};
// CRC16
function crc16(data) {
const crctab16 = new Uint16Array([
0X0000, 0XC0C1, 0XC181, 0X0140, 0XC301, 0X03C0, 0X0280, 0XC241,
0XC601, 0X06C0, 0X0780, 0XC741, 0X0500, 0XC5C1, 0XC481, 0X0440,
0XCC01, 0X0CC0, 0X0D80, 0XCD41, 0X0F00, 0XCFC1, 0XCE81, 0X0E40,
0X0A00, 0XCAC1, 0XCB81, 0X0B40, 0XC901, 0X09C0, 0X0880, 0XC841,
0XD801, 0X18C0, 0X1980, 0XD941, 0X1B00, 0XDBC1, 0XDA81, 0X1A40,
0X1E00, 0XDEC1, 0XDF81, 0X1F40, 0XDD01, 0X1DC0, 0X1C80, 0XDC41,
0X1400, 0XD4C1, 0XD581, 0X1540, 0XD701, 0X17C0, 0X1680, 0XD641,
0XD201, 0X12C0, 0X1380, 0XD341, 0X1100, 0XD1C1, 0XD081, 0X1040,
0XF001, 0X30C0, 0X3180, 0XF141, 0X3300, 0XF3C1, 0XF281, 0X3240,
0X3600, 0XF6C1, 0XF781, 0X3740, 0XF501, 0X35C0, 0X3480, 0XF441,
0X3C00, 0XFCC1, 0XFD81, 0X3D40, 0XFF01, 0X3FC0, 0X3E80, 0XFE41,
0XFA01, 0X3AC0, 0X3B80, 0XFB41, 0X3900, 0XF9C1, 0XF881, 0X3840,
0X2800, 0XE8C1, 0XE981, 0X2940, 0XEB01, 0X2BC0, 0X2A80, 0XEA41,
0XEE01, 0X2EC0, 0X2F80, 0XEF41, 0X2D00, 0XEDC1, 0XEC81, 0X2C40,
0XE401, 0X24C0, 0X2580, 0XE541, 0X2700, 0XE7C1, 0XE681, 0X2640,
0X2200, 0XE2C1, 0XE381, 0X2340, 0XE101, 0X21C0, 0X2080, 0XE041,
0XA001, 0X60C0, 0X6180, 0XA141, 0X6300, 0XA3C1, 0XA281, 0X6240,
0X6600, 0XA6C1, 0XA781, 0X6740, 0XA501, 0X65C0, 0X6480, 0XA441,
0X6C00, 0XACC1, 0XAD81, 0X6D40, 0XAF01, 0X6FC0, 0X6E80, 0XAE41,
0XAA01, 0X6AC0, 0X6B80, 0XAB41, 0X6900, 0XA9C1, 0XA881, 0X6840,
0X7800, 0XB8C1, 0XB981, 0X7940, 0XBB01, 0X7BC0, 0X7A80, 0XBA41,
0XBE01, 0X7EC0, 0X7F80, 0XBF41, 0X7D00, 0XBDC1, 0XBC81, 0X7C40,
0XB401, 0X74C0, 0X7580, 0XB541, 0X7700, 0XB7C1, 0XB681, 0X7640,
0X7200, 0XB2C1, 0XB381, 0X7340, 0XB101, 0X71C0, 0X7080, 0XB041,
0X5000, 0X90C1, 0X9181, 0X5140, 0X9301, 0X53C0, 0X5280, 0X9241,
0X9601, 0X56C0, 0X5780, 0X9741, 0X5500, 0X95C1, 0X9481, 0X5440,
0X9C01, 0X5CC0, 0X5D80, 0X9D41, 0X5F00, 0X9FC1, 0X9E81, 0X5E40,
0X5A00, 0X9AC1, 0X9B81, 0X5B40, 0X9901, 0X59C0, 0X5880, 0X9841,
0X8801, 0X48C0, 0X4980, 0X8941, 0X4B00, 0X8BC1, 0X8A81, 0X4A40,
0X4E00, 0X8EC1, 0X8F81, 0X4F40, 0X8D01, 0X4DC0, 0X4C80, 0X8C41,
0X4400, 0X84C1, 0X8581, 0X4540, 0X8701, 0X47C0, 0X4680, 0X8641,
0X8201, 0X42C0, 0X4380, 0X8341, 0X4100, 0X81C1, 0X8081, 0X4040
]);
// calculate the 16-bit CRC of data with predetermined length.
var res = 0x0ffff;
for (let b of data) {
res = ((res >> 8) & 0x0ff) ^ crctab16[(res ^ b) & 0xff];
}
return (res) & 0x0ffff;
}
// Работа с сокетами
var COMGWConnect = function() {
client.connect(COMGWPort, COMGWIP);
};
// Подключаемся к конвертеру
client.on('connect', function () {
log('** COMMGW * -> Connected to ' + COMGWIP, "info");
setState(COMGW_conn, true, true);
WatchDog = 0;
// Опрашиваем текущее состояние
Curts.forEach ( element => {
CurtainSend(element.Name, 'cmdReadPercent', 0x02);
});
});
client.on('timeout', function () {
log("** COMGW * -> Socket read/write timeout", "error");
setState(COMGW_conn, false, true);
client.destroy();
});
client.on('error', function (err) {
log("** COMGW * -> Socket Error: " + err, "error");
setState(COMGW_conn, false, true);
});
client.on('close', function (has_error) {
if(has_error) {
log("** COMGW * -> Socket close error: " + has_error, "error");
} else {
log("** COMGW * -> Socket closed", "warn");
}
setState(COMGW_conn, false, true);
});
AD
var motor = 0;
client.on('data', function (data) {
if(COMGW_debug) {
log('* COMGW -> Received: ' + toHexString(data));
log('* COMGW -> Received data lenght: ' + data.length);
}
var len = data.length;
var crc = data.readUInt16LE(len-2);
if(crc == crc16(data.subarray(0, len-2))) {
var func = data.readUInt16BE(3);
var id = data.readUInt16BE(1);
var name = Curts[Curts.findIndex(v => v.Address === id)].Name;
var val = data[5];
if(COMGW_debug) log("* COMGW -> Device: " + id.toString(16) + " Func:" + func.toString(16))
if( func == 0x0101) {
motor = val;
if(val == 0x03 && !ffAlert) {
setState('javascript.0.States.Curtains.' + name + '_state', 255, true);
sendTo('telegram.0', 'Произошел случайный сброс настроек концевых состояний по состоянию мотора в ' + name + '.');
}
}
if( func == 0x0102) {
if(val != 0xFF && motor == 0) {
setState('javascript.0.States.Curtains.' + name + '_state', val, true);
}
if(val == 0xFF && !ffAlert) {
setState('javascript.0.States.Curtains.' + name + '_state', 255, true);
sendTo('telegram.0', 'Произошел случайный сброс настроек концевых состояний по состоянию % в ' + name + '.');
}
}
if( func == 0x0304) {
if(val != 0xFF) {
setState('javascript.0.States.Curtains.' + name + '_state', val, true);
}
}
if( func == 0x0307 ) {
setState('javascript.0.States.Curtains.' + name + '_reset', false, true);
}
WatchDog = 0;
} else {
log("** COMGW * -> Read data CRC error: " + toHexString(data), "error");
}
});
function CurtainSend(Room, Cmd, Param ) {
var oRoom = Curts[(Curts.findIndex(v => v.Name === Room))];
var oCmd = CurtsCommands[CurtsCommands.findIndex(v => v.Name == Cmd)];
var buf =Buffer.alloc(oCmd.bufSize);
buf[0] = 0x55;
buf[1] = (oRoom.Address >> 8) & 0x0ff;
buf[2] = oRoom.Address & 0x0ff;
buf[3] = oCmd.cmdFunc & 0x0ff;
buf[4] = oCmd.cmdAddr & 0x0ff;
switch(oCmd.bufSize){
case 7:
var crc = crc16(buf.subarray(0,5));
buf[5] = crc & 0x0ff;
buf[6] = (crc >> 8) & 0x0ff;
break;
case 8:
buf[5] = Param & 0x0ff;
var crc = crc16(buf.subarray(0,6));
buf[6] = crc & 0x0ff;
buf[7] = (crc >> 8) & 0x0ff;
break;
}
if(COMGW_debug) log('cmdSend: ' + toHexString(buf));
client.write(buf);
}
// Отлавливаем остановку скрипта
onStop(function (callback) {
if (client) {
// close connection
log("** COMGW * -> Stopping script and socket.", "info");
client.destroy();
}
callback();
}, 2000); // / ms timeout/
var WatchDog = 0;
schedule('*/10 * * * * *', function () { //каждые 10 сек
// Авто реконнект
if(!getState(COMGW_conn).val && getState('ping.0.'+ COMGWIP.replace('2.168.118.', '2_168_118_')).val) {
log("** COMGW * -> Trying to reconnect...", "warn");
COMGWConnect();
}
if(getState(COMGW_conn).val) {
// Читаем состояние
/*
Curts.forEach ( element => {
CurtainSend(element.Name, 'cmdReadMotor', 0x01);
CurtainSend(element.Name, 'cmdReadPercent', 0x02)
});
*/
CurtainSend('Hall', 'cmdReadMotor', 0x01);
setTimeout(function() {
CurtainSend('Hall', 'cmdReadPercent', 0x02);
}, 1000);
setTimeout(function() {
CurtainSend('Bedroom', 'cmdReadMotor', 0x01);
}, 2000);
setTimeout(function() {
CurtainSend('Bedroom', 'cmdReadPercent', 0x02);
}, 3000);
// WatchDog COMGW_conn
WatchDog ++;
if (WatchDog >= 6) { // 6*10 - 60 секунд
log("** COMGW * -> WatchDog alert", "error");
client.destroy();
WatchDog = 0;
}
}
});
MZ
Благодарю!