|
|
|
|
@ -9,6 +9,7 @@ import {
|
|
|
|
|
} from '@/api/workmanagement/droneDock';
|
|
|
|
|
import TCPlayer from 'tcplayer.js';
|
|
|
|
|
import { useMessage } from '@/hooks/web/useMessage';
|
|
|
|
|
import { errorName } from '@/utils/debugging/remote';
|
|
|
|
|
|
|
|
|
|
const { createMessage } = useMessage();
|
|
|
|
|
const bid = buildGUID();
|
|
|
|
|
@ -113,8 +114,28 @@ class LiveStreamPlugin {
|
|
|
|
|
client.on('message', (topic, message) => {
|
|
|
|
|
const rs = JSON.parse(message);
|
|
|
|
|
if (rs.bid == bid) {
|
|
|
|
|
console.log(rs);
|
|
|
|
|
console.log('LiveStreamPlugin liveStartPush', rs);
|
|
|
|
|
if (rs.method == 'camera_recording_start') {
|
|
|
|
|
if (rs.data.result == 0) {
|
|
|
|
|
createMessage.success('开始录像成功');
|
|
|
|
|
} else {
|
|
|
|
|
createMessage.error('开始录像失败,' + errorName(rs.data.result));
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if (rs.method == 'live_start_push') {
|
|
|
|
|
if (rs.data.result == 0) {
|
|
|
|
|
createMessage.success('发起视频直播成功');
|
|
|
|
|
} else {
|
|
|
|
|
createMessage.error('发起视频直播失败,' + errorName(rs.data.result));
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if (rs.method == 'live_stop_push') {
|
|
|
|
|
if (rs.data.result == 0) {
|
|
|
|
|
createMessage.success('结束视频直播成功');
|
|
|
|
|
} else {
|
|
|
|
|
createMessage.error('结束视频直播失败,' + errorName(rs.data.result));
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
@ -175,6 +196,13 @@ class LiveStreamPlugin {
|
|
|
|
|
return new Promise((resolve, reject) => {
|
|
|
|
|
client.on('message', async (topic, message) => {
|
|
|
|
|
const rs = JSON.parse(message);
|
|
|
|
|
if (rs.method == 'camera_photo_take') {
|
|
|
|
|
if (rs.data.result == 0) {
|
|
|
|
|
createMessage.success('拍照成功');
|
|
|
|
|
} else {
|
|
|
|
|
createMessage.error('拍照失败,' + errorName(rs.data.result));
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if (
|
|
|
|
|
rs.method == 'flighttask_progress' &&
|
|
|
|
|
rs.data.output.status == 'in_progress' &&
|
|
|
|
|
@ -265,6 +293,13 @@ class LiveStreamPlugin {
|
|
|
|
|
return new Promise((resolve, reject) => {
|
|
|
|
|
client.on('message', async (topic, message) => {
|
|
|
|
|
const rs = JSON.parse(message);
|
|
|
|
|
if (rs.method == 'camera_recording_stop') {
|
|
|
|
|
if (rs.data.result == 0) {
|
|
|
|
|
createMessage.success('结束录像成功');
|
|
|
|
|
} else {
|
|
|
|
|
createMessage.error('结束录像失败,' + errorName(rs.data.result));
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if (
|
|
|
|
|
rs.method == 'flighttask_progress' &&
|
|
|
|
|
rs.data.output.status == 'in_progress' &&
|
|
|
|
|
|