const aliyunIot = require('../../');
|
const createTestDevices = require('./createTestDevice');
|
|
const gateway = aliyunIot.gateway({
|
productKey: '<productKey>',
|
deviceName: '<deviceName>',
|
deviceSecret: '<deviceSecret>',
|
});
|
|
gateway.on('connect', () => {
|
console.log('connect succesfully!');
|
createTestDevices().forEach(deviceConfig => {
|
// 添加子设备到拓扑
|
gateway.addTopo(deviceConfig, (err, result) => {
|
if (!err) {
|
console.log(err, result);
|
// 子设备上线
|
gateway.login(deviceConfig, (err, result) => {
|
console.log(err, result);
|
setInterval(() => {
|
console.log('开始上报');
|
// 子设备属性数据上报
|
gateway.postSubDeivceProps(
|
deviceConfig,
|
{
|
LightStatus: Math.ceil(Math.random() * 32)
|
},
|
(err, result) => {
|
console.log(err, result);
|
console.log('子设备属性上报完成！');
|
// 子设备事件上报
|
gateway.postSubDeviceEvent(
|
deviceConfig,
|
'TestEvent', // 自定义一个告警事件
|
{},
|
(err, result) => {
|
console.log(err, result);
|
console.log('子设备事件上报完成！');
|
}
|
);
|
}
|
);
|
const unsub = gateway.subTopicAndOnMessage(
|
'/sys/+/+/thing/service/#',
|
(err, topic, message) => {
|
console.log('收到 topic', err, topic, message);
|
// 取消监听
|
unsub();
|
}
|
);
|
}, 30000);
|
});
|
}
|
});
|
|
setTimeout(() => {
|
// 获取拓扑关系
|
gateway.getTopo(deviceConfig, (err, result) => {
|
console.log(err, result);
|
// 子设备下线
|
// gateway.logout(deviceConfig, (err, result) => {
|
// console.log(err, result);
|
// // 移除拓扑关系
|
// gateway.deleteTopo(deviceConfig, (err, result) => {
|
// console.log(err, result);
|
// });
|
// });
|
});
|
}, 2000);
|
});
|
});
|
