Dooya DT82 (Onviz MR-2234F)

Поддерживаемые устройства
15

Проверьте:

//Путь к RPC
var pathRPC = "/rpc/v1/wb-mqtt-serial/port/Load/";

 
function createBlind(NameBlind, portBlind, speedPortBlind, pariryBlid, stopBitBlind, blindCh_L, blindCh_H){
  //Создаем виртуальное устройство
  makeNewVirtualControl(NameBlind, "position", {type: "range", value: 0, min: 0, max: 200, readonly: false});
  makeNewVirtualControl(NameBlind, "position_in", {type: "range", value: 0, min: 0, max: 200, readonly: false});
  // кнопка "Открыть" (работает)
  makeNewVirtualControl(NameBlind, "open", {type: "pushbutton", readonly: false});
  // кнопка "Стоп"(Работает)
  makeNewVirtualControl(NameBlind, "Stop", {type: "pushbutton", readonly: false});
  // кнопка "Закрыть" (работает)
  makeNewVirtualControl(NameBlind, "close", {type: "pushbutton", readonly: false});
  // Активность мотора (1 - вращается)
  makeNewVirtualControl(NameBlind, "MotorRun", {type: "switch", readonly: true});
  // временный для отладки
  makeNewVirtualControl(NameBlind, "reply", {type: "text", value: "", readonly: false});
  
  //open: 
  defineRule(NameBlind+"_rule_open",{
  whenChanged: NameBlind+"/open",
    then: function () {
      log.info(NameBlind+"_open")
      //Формируем запрос 0a dd 
      var req = blindRequestMsg(blindCh_L, blindCh_H, 0x03, 0x01);
      log.info("open=", req)
      //Вызовем запрос
      requestRPC(portBlind, speedPortBlind, pariryBlid, stopBitBlind, NameBlind, 1, "HEX", req, 0 );
    }
  });
  //Stop: 
  defineRule(NameBlind+"_rule_Stop",{
  whenChanged: NameBlind+"/Stop",
    then: function () {
      //Формируем запрос 0a 0d 
      var req = blindRequestMsg(blindCh_L, blindCh_H, 0x03, 0x03);
      log.info("req_Stop=", req)
      //Вызовем запрос, не ожидая ответ. На команды ответа нет.
      requestRPC(portBlind, speedPortBlind, pariryBlid, stopBitBlind, NameBlind, 1, "HEX", req, 0 );
    }
  });
  //close: 
  defineRule(NameBlind+"_rule_close",{
  whenChanged: NameBlind+"/close",
    then: function () {
      //Формируем запрос 0a ee 
      var req = blindRequestMsg(blindCh_L, blindCh_H, 0x03, 0x02);
      //log.info("close=", req)
      requestRPC(portBlind, speedPortBlind, pariryBlid, stopBitBlind, NameBlind, 1, "HEX", req, 0 );
    }
  });
  //Сделаем таймер, который будет опрашивать позицию, возвращая ее в контрол.
/*  startTicker(NameBlind+"_timer", 6000);
  //И правило, работающее по срабатыванию таймера
  defineRule(NameBlind+"_rule",{
  when: function () { return timers[NameBlind+"_timer"].firing; },
    then: function () {
      var req = blindRequestMsg(blindCh_L, blindCh_H, 0x03, 0x04);
      //log.info("req_timer "+NameBlind+"=", req)
      //Вызовем запрос, ожидая 9 байт в ответ
      requestRPC(portBlind, speedPortBlind, pariryBlid, stopBitBlind, NameBlind, 1, "HEX", req, 9 );
    }
  });
*/
  
  trackMqtt(pathRPC+NameBlind+"/reply", function(message){
    log.info("from "+NameBlind+" name: {}, value: {}".format(message.topic, message.value))
    var replyObj = JSON.parse(message.value);
    //log.info("from "+NameBlind+" replyObj.error: ", replyObj.error)
    //log.info("from "+NameBlind+" replyObj.result.response: {}".format(replyObj.result.response))
    dev[NameBlind]["reply"] = replyObj.result.response;
  });
  
  return 0
}

function requestRPC(modbusPort, modbusSpeed, modbusParity, reqStopbit, clientID, requiestID, messageType, message, responseSize){
  //Формируем JSON запрос. Должно быть что-то такое:
  //{"params": {"response_size": 8, "format": "HEX", "path": "/dev/ttyRS485-1", "baud_rate": 9600, "parity" : "N", "data_bits" : 8, "stop_bits" : 1, "msg": "0A03008000018499"}, "id" : 1}
  var strJson = JSON.stringify({params: {response_size: responseSize, format: messageType, path: modbusPort, "baud_rate": modbusSpeed, parity: modbusParity, "data_bits" : 8, "stop_bits" : reqStopbit, "msg": message}, "id" : requiestID})
  publish(pathRPC+clientID, strJson, 2, false);
}

function blindRequestMsg(blindCh_L, blindCh_H, commandBlind, dataBlind){
  //Сформируем набор байт команды. Первый байт всегда 55.
  //отсутствует для текущего - blindID
  //Второй - blindCh_L
  //третий - blindCh_H
  //четыертый - функция
  //пятый - данные функции
  //шестой - crc16_l
  //седьмой - crc16_h
    //Для "открыть", проверочный  55 fe fe 03 01 AD 8A
  //на входе ожидаем целые без знака.

  //Вычисляем CRC.
  var verify = crc16modbus([0x55,toHexStr(blindCh_L),toHexStr(blindCh_H),toHexStr(commandBlind),toHexStr(dataBlind)])
  // CRC16 возвращается, но он может быть короче двух байт (меньше 256) и перым надо отправлять его младший байт.
  verify=toHexStr(verify)
  //log.info("verifyHEX=", verify)
  verify_L = "0x"+verify & 0x00FF
  //log.info("verifyHEX_L=", "0x"+verify & 0x00FF)
  verify_H = "0x"+verify & 0xFF00
  //log.info("verifyHEX_H=", "0x"+verify & 0xFF00)
  
  //Готовим строку
  return "55"+toHexStr(blindCh_L)+toHexStr(blindCh_H)+toHexStr(commandBlind)+toHexStr(dataBlind)+toHexStr(verify_L)+toHexStr(verify_H);
}

function crc16modbus(buffer) {
    var crc = 0xFFFF;
    var odd;

    for (var i = 0; i < buffer.length; i++) {
        crc = crc ^ buffer[i];

        for (var j = 0; j < 8; j++) {
            odd = crc & 0x0001;
            crc = crc >> 1;
            if (odd) {
                crc = crc ^ 0xA001;
            }
        }
    }
    return crc;
};

function toHexStr(inArg){
  //На входе int, на выходе hex строка дополненные нулями спереди
  var tmp = inArg.toString(16);
  if (tmp.length < 2) {tmp = "0"+tmp};
  return tmp;
}

function makeNewVirtualControl(vdName, nameControl, typeControl){
  //log.info("GetDevice", getDevice("vdName"))
  if (getDevice(vdName) === undefined) {
    log.info("Define new")
    defineVirtualDevice(vdName, {
      title: vdName,
      cells: {},
    })
  }
     //Тут проверим есть ли уже контрол и если нет - создадим.
    if (!getDevice(vdName).isControlExists(nameControl)) {
      log.debug("Контрола "+nameControl+" нет, создаем.")
      getDevice(vdName).addControl(nameControl, typeControl);
    }
}

//Создаем виртуальное устройство, с контролами для шторы. По строчке на одну штору.
//                имя               порт        bod   parity   stopbit  ID_L   ID_H
createBlind("ONVIZ MR2234F", "/dev/ttyRS485-1", 9600, "N",      1,      1,     1,    1)

Кнопка “open” выдает

open= 5501010301b900