|
|
|
@ -138,7 +138,7 @@ class LiveStreamPlugin {
|
|
|
|
|
* zpkzxx:照片扩展信息
|
|
|
|
|
*/
|
|
|
|
|
console.log('LiveStreamPlugin takePicture', callback);
|
|
|
|
|
servicesTopic(sn, {
|
|
|
|
|
const querys = {
|
|
|
|
|
bid: bid,
|
|
|
|
|
method: 'camera_photo_take',
|
|
|
|
|
tid: buildGUID(),
|
|
|
|
@ -146,7 +146,9 @@ class LiveStreamPlugin {
|
|
|
|
|
data: {
|
|
|
|
|
payload_index: uav.camera_index,
|
|
|
|
|
},
|
|
|
|
|
});
|
|
|
|
|
};
|
|
|
|
|
console.log(querys);
|
|
|
|
|
servicesTopic(sn, querys);
|
|
|
|
|
const data = {};
|
|
|
|
|
callback(data);
|
|
|
|
|
}
|
|
|
|
@ -212,25 +214,20 @@ class LiveStreamPlugin {
|
|
|
|
|
client.subscribe('thing/product/' + serialNum + '/events', { qos: 2 }, () => {});
|
|
|
|
|
// 接收消息
|
|
|
|
|
let id = '';
|
|
|
|
|
client.on('message', async (topic, message) => {
|
|
|
|
|
const rs = JSON.parse(message);
|
|
|
|
|
if (
|
|
|
|
|
rs.method == 'flighttask_progress' &&
|
|
|
|
|
rs.data.output.status == 'in_progress' &&
|
|
|
|
|
id == ''
|
|
|
|
|
) {
|
|
|
|
|
console.log(rs);
|
|
|
|
|
id = rs.data.output.ext.flight_id;
|
|
|
|
|
return new Promise((resolve, reject) => {
|
|
|
|
|
return new Promise((resolve, reject) => {
|
|
|
|
|
client.on('message', async (topic, message) => {
|
|
|
|
|
const rs = JSON.parse(message);
|
|
|
|
|
if (
|
|
|
|
|
rs.method == 'flighttask_progress' &&
|
|
|
|
|
rs.data.output.status == 'in_progress' &&
|
|
|
|
|
id == ''
|
|
|
|
|
) {
|
|
|
|
|
id = rs.data.output.ext.flight_id;
|
|
|
|
|
getDroneDockflightInfos(id).then((res) => {
|
|
|
|
|
console.log(res);
|
|
|
|
|
resolve(res);
|
|
|
|
|
});
|
|
|
|
|
});
|
|
|
|
|
return await getDroneDockflightInfos(id).then((res) => {
|
|
|
|
|
return res;
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|