【IoT迷你赛】使用门磁传感器和JS控制小米智能灯

function RawToProtocol(fPort, bytes) {
    const COMMAND_A1_UNBOUND = 0x02;
    const COMMAND_A1_BOUND = 0x03;
    const COMMAND_07_FLAG_MODE = 0x05;
    const COMMAND_07_LEN_MODE = 1;
    const COMMAND_07_FLAG_VER = 0x90;
    const COMMAND_07_LEN_VER = 3;
    const COMMAND_07_FLAG_DELAY = 0x9c;
    const COMMAND_07_LEN_DELAY = 2;
    const COMMAND_07_FLAG_ULPRD = 0x9d;
    const COMMAND_0f_ALERT_KIND = 0x20;
    const COMMAND_0f_ALERT_OPEN = 2;
    const COMMAND_0f_ALERT_CLOSE = 4;
    
    var data = {
        "method": "report",
        "clientToken" : new Date(),
        "params" : {}
    };
    switch (bytes[0]) {
        case 0xA1:
        if (bytes[1] == COMMAND_A1_UNBOUND) {
            data.params.bound = 0;
        } else if (bytes[1] == COMMAND_A1_BOUND) {
            data.params.bound = 1;
        }
        break;
        case 0x07:
        for (let i = 1; i < bytes.length; i++) {
            if (bytes[i] == COMMAND_07_FLAG_MODE) {
                i += COMMAND_07_LEN_MODE;
            } else if (bytes[i] == COMMAND_07_FLAG_VER) {
                i += COMMAND_07_LEN_VER;
            } else if (bytes[i] == COMMAND_07_FLAG_DELAY) {
                i += COMMAND_07_LEN_DELAY;
            } else if (bytes[i] == COMMAND_07_FLAG_ULPRD) {
                data.params.period = bytes[i+1] | (bytes[i+2] << 8);
            }
        }
        break;
        case 0x00:
        if (bytes[5] & 0x80) {
            data.params.isOpen = 0;
        } else {
            data.params.isOpen = 1;
        }
        break;
        case 0x0f:
        if (bytes[1] == COMMAND_0f_ALERT_KIND) {
            if (bytes[2] == COMMAND_0f_ALERT_OPEN) {
                data.params.isOpen = 1;
            } else if (bytes[2] == COMMAND_0f_ALERT_CLOSE) {
                data.params.isOpen = 0;
            }
        }
        break;
    }
    return data;
}

function ProtocolToRaw(obj) {
    var data = new Array();
    var i = 0;

    data[i++] = 8;// fport=8
    data[i++] = 1;// confirmed mode
    for (var property in obj.params) {
        if ((property == "bound") && (obj.params[property] == 1)) {
            data[i++] = 0xA1;
            data[i++] = 0x03;
        }
        if (property == "period") {
            data[i++] = 0x9D;
            data[i++] = obj.params[property] & 0x00FF;
            data[i++] = (obj.params[property] >> 8) & 0x00FF;
        }
    }
    return data;
}

var Yeelight = require('node-yeelight');
var y = new Yeelight;

y.on('ready', function() {
	console.log('ready');
	y.discover();
});

y.on('deviceadded', function(device) {
	console.log('device added');
	y.connect(device);
});

var deviceList = [];
y.on('deviceconnected', function(device) {
	console.log('device connected');
    deviceList.push(device);
    var state = true;
    setTimeout(function(){
        setInterval(function() {

            // 设置灯泡开关及过度时间
            // y.setPower(device, state, 2500);
    
            state = state ? false : true;
            
            // 设置灯泡亮度
            y.setBrightness(
                device, // device object
                state?100:1, // brightness percentage (1-100)
                800 // transition speed in ms
            );
        }, 1000);
    },(deviceList.length-1)*1000);
	
});

y.listen();

//腾讯云传感器初始化
const tencentcloud = require("tencentcloud-sdk-nodejs");

const IotexplorerClient = tencentcloud.iotexplorer.XXXX.Client;
const models = tencentcloud.iotexplorer.XXXX.Models;

const Credential = tencentcloud.common.Credential;
const ClientProfile = tencentcloud.common.ClientProfile;
const HttpProfile = tencentcloud.common.HttpProfile;

let cred = new Credential("XXXXX", "XXXXXX");
let httpProfile = new HttpProfile();
httpProfile.endpoint = "iotexplorer.tencentcloudapi.com";
let clientProfile = new ClientProfile();
clientProfile.httpProfile = httpProfile;
let client = new IotexplorerClient(cred, "ap-guangzhou", clientProfile);

let req = new models.DescribeDeviceDataRequest();

let params = '{"ProductId":"XXXX","DeviceName":"dev001"}'
req.from_json_string(params);

//yeelight 初始化

var Yeelight = require('node-yeelight');
var y = new Yeelight;

y.on('ready', function() {
	console.log('ready');
	y.discover();
});

y.on('deviceadded', function(device) {
	console.log('device added');

	y.connect(device);
});

var deviceList = [];
y.on('deviceconnected', function(device) {
	console.log('device connected');
    deviceList.push(device);
});

y.listen();

// 监听门窗传感器
var isOpen;
var interval = setInterval(function(){
    client.DescribeDeviceData(req, function(errMsg, response) {

        if (errMsg) {
            console.log(errMsg);
            clearInterval(interval);
            return;
        }

        // console.log(response.to_json_string());
        var data = JSON.parse(response.Data);
        if(data.isOpen.Value != isOpen){
            isOpen = data.isOpen.Value;
            let isOpenStr = isOpen == 1 ? "open":"close";
            console.log(`the door is ${isOpenStr}`)
            deviceList.forEach((device)=>{
                y.setPower(device, isOpen == 1, 100);
            });
        }
    });
},500);