gitY
/
DiKongGanZhiPingTai
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

MQTT增加用户锁，连接id增加逻辑

main
刘妍 2025-06-26 17:18:49 +08:00
parent 94fa1b4309
commit 14c5a0241f
8 changed files with 365 additions and 121 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/api/workmanagement/airportMaintenance.ts
View File

@ -1,11 +1,19 @@
import { defHttp } from '@/utils/http/axios'; import { defHttp } from '@/utils/http/axios';
import { StartLiveParams, SetCameraVideoParams, ExchangeCameraParams } from './model/index'; import {
StartLiveParams,
SetCameraVideoParams,
ExchangeCameraParams,
AddOrUpdateRedisUserParams,
} from './model/index';
enum Api { enum Api {
StartLive = '/api/AirportMaintenance/StartLive', StartLive = '/api/AirportMaintenance/StartLive',
EndLive = '/api/AirportMaintenance/EndLive', EndLive = '/api/AirportMaintenance/EndLive',
SetCameraVideo = '/api/AirportMaintenance/SetCameraVideo', SetCameraVideo = '/api/AirportMaintenance/SetCameraVideo',
ExchangeCamera = '/api/AirportMaintenance/ExchangeCamera', ExchangeCamera = '/api/AirportMaintenance/ExchangeCamera',
GetRedisUser = '/api/AirportMaintenance/GetRedisUser',
GetLockedClients = '/api/AirportMaintenance/GetLockedClients',
AddOrUpdateRedisUser = '/api/AirportMaintenance/AddOrUpdateRedisUser',
} }
export const startLive = (params: StartLiveParams) => export const startLive = (params: StartLiveParams) =>
@ -30,3 +38,16 @@ export const exchangeCamera = (params: ExchangeCameraParams) =>
url: Api.ExchangeCamera, url: Api.ExchangeCamera,
params, params,
}); });
export function getRedisUser(id) {
return defHttp.get({ url: Api.GetRedisUser + '?id=' + id });
}
export function getLockedClients(params?: any) {
return defHttp.get({ url: Api.GetLockedClients, params });
}
export const addOrUpdateRedisUser = (params: AddOrUpdateRedisUserParams) =>
defHttp.post({
url: Api.AddOrUpdateRedisUser,
params,
});

8
src/api/workmanagement/model/index.ts
View File

@ -20,3 +20,11 @@ export interface ExchangeCameraParams {
position?: number; position?: number;
camera?: string; camera?: string;
} }
export interface AddOrUpdateRedisUserParams {
clientId?: string;
userId?: string;
userName?: string;
connectTime?: string;
isLock?: boolean;
}

112
src/utils/mqtt.ts
View File

@ -1,5 +1,11 @@
import mqtt from 'mqtt'; import mqtt from 'mqtt';
import { useMessage } from '@/hooks/web/useMessage'; import { useMessage } from '@/hooks/web/useMessage';
import { getRedisUser, addOrUpdateRedisUser } from '@/api/workmanagement/airportMaintenance';
import { useUserStore } from '@/store/modules/user';
import { timestampToFormattedDate } from '@/utils/index';
const userStore = useUserStore();
const userInfo = userStore.getUserInfo;
const { createMessage } = useMessage(); const { createMessage } = useMessage();
const connection = { const connection = {
@ -12,8 +18,8 @@ const connection = {
clean: true, clean: true,
connectTimeout: 30 * 1000, // ms connectTimeout: 30 * 1000, // ms
reconnectPeriod: 4000, // ms reconnectPeriod: 4000, // ms
// clientId: 'mqttx_' + Math.random().toString(16).substring(2, 8), clientId: '',
clientId: 'mqtt_client_1581F8HGX254V00A0BUY', // clientId: 'mqtt_client_1581F8HGX254V00A0BUY',
// auth // auth
username: 'sdhc', username: 'sdhc',
password: '', password: '',
@ -44,32 +50,41 @@ const handleOnReConnect = () => {
}; };
// 创建连接函数 // 创建连接函数
const createConnection = (callback?) => { const createConnection = (callback?) => {
console.log('创建连接');
// 连接mqtt的时候，先用GetRedisUser查一下有没有，
// 然后AddOrUpdateRedisUser更新或添加，
// 控制的时候先查一下有没有锁定的用户GetLockedClients
try { try {
getRedisUser(userInfo.id).then((res) => {
console.log(res);
if (res) {
connection.clientId = res.clientId;
} else {
const clientId = 'mqttx_' + Math.random().toString(16).substring(2, 8);
connection.clientId = clientId;
const querys = {
clientId: clientId,
userId: userInfo.id,
userName: userInfo.name,
isLock: false,
connectTime: timestampToFormattedDate(new Date().getTime()),
};
addOrUpdateRedisUser(querys);
}
});
// const clientId = 'mqttx_' + Math.random().toString(16).substring(2, 8);
// connection.clientId = clientId;
const { protocol, host, port, endpoint, ...options } = connection; const { protocol, host, port, endpoint, ...options } = connection;
const connectUrl = `${protocol}://${host}:${port}${endpoint}`; const connectUrl = `${protocol}://${host}:${port}${endpoint}`;
client = mqtt.connect(connectUrl, options); client = mqtt.connect(connectUrl, options);
client.on('connect', () => {
// console.log('✅ 已连接');
if(callback){
callback()
}
});
client.on('close', () => {
// console.log('❌ 连接已关闭');
});
client.on('error', (err) => {
// console.error('❌ 出错了:', err);
});
if (client.on) {
}
} catch (error) { } catch (error) {
console.log('mqtt.connect error', error); console.log('mqtt.connect error', error);
} }
}; };
const getClient = () => { const getClient = () => {
if (!client || !client.connected) { // if (!client || !client.connected) {
createConnection(); // createConnection();
} // }
return client; return client;
}; };
// 断开连接 // 断开连接
@ -87,20 +102,16 @@ const destroyConnection = () => {
}; };
// 订阅事件 // 订阅事件
const clientSubscribe = (topic: string, options?: any) => { const clientSubscribe = (topic: string, options?: any) => {
console.log(client); // if (!client || !client.connected) {
if (!client || !client.connected) { // createConnection();
createConnection(); // }
} getClient().subscribe(topic, { qos: 0 }, (error, res) => {});
getClient().subscribe(topic, { qos: 0 }, (error, res) => {
console.log('订阅');
console.log(error, res);
});
}; };
// 发送消息 // 发送消息
const clientPublish = (topic: string, querys: any) => { const clientPublish = (topic: string, querys: any) => {
if (!client || !client.connected) { // if (!client || !client.connected) {
createConnection(); // createConnection();
} // }
getClient().publish(topic, JSON.stringify(querys), { qos: 0 }, (err) => { getClient().publish(topic, JSON.stringify(querys), { qos: 0 }, (err) => {
if (err) { if (err) {
console.error('Publish error:', err); console.error('Publish error:', err);
@ -109,12 +120,11 @@ const clientPublish = (topic: string, querys: any) => {
}; };
// 获取连接状态 // 获取连接状态
const getConnectStatus = () => { const getConnectStatus = () => {
console.log('client',client)
if (!client.connected) { if (!client.connected) {
return false return false;
} }
return true return true;
} };
// on 事件 // on 事件
// connect 连接 // connect 连接
// reconnect 重新连接 // reconnect 重新连接
@ -143,18 +153,31 @@ const createSeizeConnection = () => {
console.log('mqtt.connect error', error); console.log('mqtt.connect error', error);
} }
}; };
const getReizeClient = () => { const destroySeizeConnection = () => {
if (!client_seize || !client_seize.connected) { if (client_seize.connected) {
createSeizeConnection(); try {
client_seize.end(false, () => {
client_seize = {
connected: false,
};
console.log('Successfully disconnected!');
});
} catch (error) {
console.log('Disconnect failed', error.toString());
}
} }
};
const getReizeClient = () => {
// if (!client_seize || !client_seize.connected) {
// createSeizeConnection();
// }
return client_seize; return client_seize;
}; };
// 订阅事件 // 订阅事件
const clientReizeSubscribe = (topic: string, options?: any) => { const clientReizeSubscribe = (topic: string, options?: any) => {
console.log(client_seize); // if (!client_seize || !client_seize.connected) {
if (!client_seize || !client_seize.connected) { // createSeizeConnection();
createConnection(); // }
}
getReizeClient().subscribe(topic, { qos: 0 }, (error, res) => { getReizeClient().subscribe(topic, { qos: 0 }, (error, res) => {
console.log('订阅'); console.log('订阅');
console.log(error, res); console.log(error, res);
@ -162,9 +185,9 @@ const clientReizeSubscribe = (topic: string, options?: any) => {
}; };
// 发送消息 // 发送消息
const clientReizePublish = (topic: string, querys: any) => { const clientReizePublish = (topic: string, querys: any) => {
if (!client_seize || !client_seize.connected) { // if (!client_seize || !client_seize.connected) {
createConnection(); // createSeizeConnection();
} // }
getReizeClient().publish(topic, JSON.stringify(querys), { qos: 0 }, (err) => { getReizeClient().publish(topic, JSON.stringify(querys), { qos: 0 }, (err) => {
if (err) { if (err) {
console.error('Publish error:', err); console.error('Publish error:', err);
@ -179,6 +202,7 @@ export {
clientSubscribe, clientSubscribe,
clientPublish, clientPublish,
createSeizeConnection, createSeizeConnection,
destroySeizeConnection,
getReizeClient, getReizeClient,
clientReizeSubscribe, clientReizeSubscribe,
clientReizePublish, clientReizePublish,

8
src/views/demo/workmanagement/flightoperation/index.vue
View File

@ -53,7 +53,7 @@
</div> </div>
</template> </template>
<script setup lang="ts"> <script setup lang="ts">
import { onMounted, ref } from 'vue'; import { onMounted, ref, onBeforeUnmount } from 'vue';
import { import {
SelectComponent, SelectComponent,
AirportInformation, AirportInformation,
@ -68,7 +68,7 @@
FlyToForm, FlyToForm,
} from './index'; } from './index';
import { useMessage } from '@/hooks/web/useMessage'; import { useMessage } from '@/hooks/web/useMessage';
import { getClient, createConnection, clientSubscribe } from '@/utils/mqtt'; import { getClient, createConnection, clientSubscribe, destroyConnection } from '@/utils/mqtt';
import { buildGUID } from '@/utils/uuid'; import { buildGUID } from '@/utils/uuid';
import { vDrag } from '@/utils/drag'; import { vDrag } from '@/utils/drag';
@ -80,11 +80,15 @@
name: null, name: null,
}); });
onMounted(() => { onMounted(() => {
destroyConnection();
createConnection(); createConnection();
setTimeout(() => { setTimeout(() => {
changeSelect(); changeSelect();
}, 1000); }, 1000);
}); });
onBeforeUnmount(() => {
destroyConnection();
});
const changeSelectValue = ref(); const changeSelectValue = ref();
// 机场直播 // 机场直播
const airportLiveVisible = ref(true); const airportLiveVisible = ref(true);

3
src/views/demo/workmanagement/flightoperation/src/AirportLive.vue
View File

@ -47,9 +47,11 @@
if (val.message.data.result == 0) { if (val.message.data.result == 0) {
createMessage.success('开始直播成功'); createMessage.success('开始直播成功');
player.src('http://175.27.168.120:6012/live/2.flv'); player.src('http://175.27.168.120:6012/live/2.flv');
player.play();
} else if (val.message.data.result == 513003) { } else if (val.message.data.result == 513003) {
createMessage.success('直播已开启'); createMessage.success('直播已开启');
player.src('http://175.27.168.120:6012/live/2.flv'); player.src('http://175.27.168.120:6012/live/2.flv');
player.play();
} else { } else {
createMessage.error('开始直播失败'); createMessage.error('开始直播失败');
} }
@ -133,6 +135,7 @@
}, },
], ],
licenseUrl: 'http://175.27.168.120:6012/live/2.flv', // license 地址，必传。参考准备工作部分，在视立方控制台申请 license 后可获得 licenseUrl licenseUrl: 'http://175.27.168.120:6012/live/2.flv', // license 地址，必传。参考准备工作部分，在视立方控制台申请 license 后可获得 licenseUrl
autoplay: true, // 是否自动播放
}); });
}, 1000); }, 1000);
}); });

163
src/views/demo/workmanagement/flightoperation/src/FlightControl.vue
View File

@ -1,14 +1,23 @@
<template> <template>
<div class="flight-control" v-if="airportVal" v-drag> <div class="flight-control" v-if="airportVal" v-drag>
<div class="title"> <div class="title">
<div> 飞行控制：<i>暂无 </i> </div> <div>
飞行控制：
<!-- {"0":"空闲中","1":"现场调试","2":"远程调试","3":"固件升级中","4":"作业中","5":"待标定"} -->
<i v-if="airportVal.mode_code == 0">空闲中 </i>
<i v-else-if="airportVal.mode_code == 1">现场调试 </i>
<i v-else-if="airportVal.mode_code == 2">远程调试 </i>
<i v-else-if="airportVal.mode_code == 3">固件升级中 </i>
<i v-else-if="airportVal.mode_code == 4">作业中 </i>
<i v-else-if="airportVal.mode_code == 5">待标定 </i>
</div>
<div @click="emits('changeFlightControl')"> <div @click="emits('changeFlightControl')">
<CloseOutlined /> <CloseOutlined />
</div> </div>
</div> </div>
<div class="content"> <div class="content">
<div class="content-button"> <div class="content-button">
<a-button @click="emits('clickTakeOff')">一键起飞</a-button> <a-button @click="takeOff">一键起飞</a-button>
<a-button @click="emits('clickFlyTo')">指点飞行</a-button> <a-button @click="emits('clickFlyTo')">指点飞行</a-button>
<!-- <a-button>智能环绕</a-button> --> <!-- <a-button>智能环绕</a-button> -->
<a-button @click="returnVoyage">一键返航</a-button> <a-button @click="returnVoyage">一键返航</a-button>
@ -37,7 +46,7 @@
</template> </template>
<script setup lang="ts"> <script setup lang="ts">
import { onMounted, ref, watch, reactive, onUnmounted } from 'vue'; import { onMounted, ref, watch, reactive, onUnmounted } from 'vue';
import { getClient, createConnection } from '@/utils/mqtt'; import { getClient, createSeizeConnection, destroySeizeConnection } from '@/utils/mqtt';
import { CloseOutlined } from '@ant-design/icons-vue'; import { CloseOutlined } from '@ant-design/icons-vue';
import { vDrag } from '@/utils/drag'; import { vDrag } from '@/utils/drag';
import { drcDownTopicReize, eventsTopicSubscribeReize } from '@/utils/debugging/events'; import { drcDownTopicReize, eventsTopicSubscribeReize } from '@/utils/debugging/events';
@ -49,13 +58,23 @@
} from '@/utils/debugging/remote'; } from '@/utils/debugging/remote';
import { buildGUID } from '@/utils/uuid'; import { buildGUID } from '@/utils/uuid';
import { useMessage } from '@/hooks/web/useMessage'; import { useMessage } from '@/hooks/web/useMessage';
import {
getRedisUser,
addOrUpdateRedisUser,
getLockedClients,
} from '@/api/workmanagement/airportMaintenance';
import { useUserStore } from '@/store/modules/user';
import { timestampToFormattedDate } from '@/utils/index';
const userStore = useUserStore();
const userInfo = userStore.getUserInfo;
const redisUser = ref({});
const { createMessage } = useMessage(); const { createMessage } = useMessage();
const emits = defineEmits(['changeFlightControl', 'clickTakeOff', 'clickFlyTo']); const emits = defineEmits(['changeFlightControl', 'clickTakeOff', 'clickFlyTo']);
const props = defineProps({ // 是否飞行控制权抢夺
airportAllVal: Object, const flightGrab = ref(false);
}); // 是否进入飞行指令控制模式
console.log(props); const modeEnter = ref(false);
const airportVal: any = ref({ const airportVal: any = ref({
mode_code: 0, mode_code: 0,
wind_speed: 0, wind_speed: 0,
@ -77,39 +96,66 @@
yaw: 1024, yaw: 1024,
gimbal_pitch: 1024, gimbal_pitch: 1024,
}); });
watch( //修改redis用户锁
() => props.airportAllVal, const changeRedisUser = (val: boolean) => {
(val) => { const querys = redisUser.value;
console.log(val); querys.isLock = val;
airportVal.value = val.data; querys.connectTime = timestampToFormattedDate(new Date().getTime());
}, addOrUpdateRedisUser(querys);
); };
const isLocked = ref(false);
// 判断有没有redis用户锁
const lockedClient = () => {
getLockedClients().then((res) => {
console.log(res);
if (res.length > 0) {
res.forEach((item, index) => {
if (item.userId != userInfo.id) {
isLocked.value = true;
}
});
}
});
};
// 一键起飞
const takeOff = () => {
if (isLocked.value) {
createMessage.success('当前有用户正在操作，请稍后再试');
return;
}
emits('clickTakeOff');
changeRedisUser(true);
};
// 获取 // 获取
const obtain = () => { const obtain = () => {
if (!getClient()) { // if (!getClient()) {
createConnection(); // createConnection();
// }
if (isLocked.value) {
createMessage.success('当前有用户正在操作，请稍后再试');
return;
} }
setTimeout(() => { changeRedisUser(true);
// 飞行控制权抢夺 // 飞行控制权抢夺
servicesTopic({ servicesTopic({
bid: buildGUID(), bid: buildGUID(),
method: 'flight_authority_grab', method: 'flight_authority_grab',
tid: buildGUID(), tid: buildGUID(),
timestamp: new Date().getTime(), timestamp: new Date().getTime(),
data: {}, data: {},
}); });
// 负载控制权抢夺 // 负载控制权抢夺
servicesTopic({ servicesTopic({
bid: buildGUID(), bid: buildGUID(),
method: 'payload_authority_grab', method: 'payload_authority_grab',
tid: buildGUID(), tid: buildGUID(),
timestamp: new Date().getTime(), timestamp: new Date().getTime(),
data: { data: {
payload_index: '99-0-0', payload_index: '99-0-0',
}, },
}); });
services_replyTopic(); services_replyTopic();
}, 1000);
}; };
// 一键返航 // 一键返航
const returnVoyage = () => { const returnVoyage = () => {
@ -125,11 +171,19 @@
}; };
const seq = ref(1); const seq = ref(1);
const changeDRC = (type, value) => { const changeDRC = (type, value) => {
if (!modeEnter.value) {
createMessage.warning('请先进入指令飞行控制');
return;
}
seq.value = seq.value + 1; seq.value = seq.value + 1;
if (value == 'up') { if (value == 'up') {
data[type] = data[type] + 20; if (data[type] < 1684) {
data[type] = data[type] + 20;
}
} else { } else {
data[type] = data[type] - 20; if (data[type] > 364) {
data[type] = data[type] - 20;
}
} }
const querys = { const querys = {
seq: seq.value, seq: seq.value,
@ -144,6 +198,11 @@
}; };
const drcSeq = ref(1); const drcSeq = ref(1);
const enterDRC = () => { const enterDRC = () => {
if (!flightGrab.value) {
createMessage.warning('请先获取飞行控制权');
return;
}
createSeizeConnection();
// 进入指令飞行控制模式 // 进入指令飞行控制模式
const querys = { const querys = {
bid: buildGUID(), bid: buildGUID(),
@ -200,20 +259,44 @@
servicesTopic(querys); servicesTopic(querys);
}; };
onMounted(() => { onMounted(() => {
// 获取mqtt客户端信息
getRedisUser(userInfo.id).then((res) => {
console.log(res);
if (res) {
redisUser.value = res;
}
});
lockedClient();
// // 接收消息 // // 接收消息
getClient().on('message', (topic, message) => { getClient().on('message', (topic, message) => {
const rs = JSON.parse(message); const rs = JSON.parse(message);
if (rs.data.mode_code || rs.data.mode_code == 0) {
airportVal.value = rs.data;
}
if (rs.method == 'flight_authority_grab') {
console.log(rs);
if (rs.data.result == 0) {
flightGrab.value = true;
createMessage.success('飞行控制权抢夺成功');
} else {
flightGrab.value = false;
createMessage.error('飞行控制权抢夺失败，状态码' + rs.data.result);
}
}
if (rs.method == 'drc_mode_enter') { if (rs.method == 'drc_mode_enter') {
console.log(rs); console.log(rs);
if (rs.data.result == 0) { if (rs.data.result == 0) {
modeEnter.value = true;
createMessage.success('进入指令飞行控制模式成功'); createMessage.success('进入指令飞行控制模式成功');
} else { } else {
modeEnter.value = false;
createMessage.error('进入指令飞行控制模式失败，状态码' + rs.data.result); createMessage.error('进入指令飞行控制模式失败，状态码' + rs.data.result);
} }
} }
if (rs.method == 'drc_mode_exit') { if (rs.method == 'drc_mode_exit') {
console.log(rs); console.log(rs);
if (rs.data.result == 0) { if (rs.data.result == 0) {
modeEnter.value = false;
createMessage.success('退出指令飞行控制模式成功'); createMessage.success('退出指令飞行控制模式成功');
} else { } else {
createMessage.error('退出指令飞行控制模式失败，状态码' + rs.data.result); createMessage.error('退出指令飞行控制模式失败，状态码' + rs.data.result);
@ -248,6 +331,8 @@
}); });
onUnmounted(() => { onUnmounted(() => {
window.clearInterval(timer); window.clearInterval(timer);
destroySeizeConnection();
changeRedisUser(false);
}); });
</script> </script>
<style lang="less" scoped> <style lang="less" scoped>

167
src/views/demo/workmanagement/flightoperation/src/LoadControl.vue
View File

@ -7,19 +7,21 @@
</div> </div>
</div> </div>
<div class="content"> <div class="content">
<div class="content-item"> <!-- <div class="content-item">
<span>相机控制权</span> <span>相机控制权</span>
<a-button @click="obtain">获取</a-button> <a-button @click="obtain">获取</a-button>
</div> </div> -->
<!-- <div class="content-item"> <!-- <div class="content-item">
<span>切换相机模式</span> <span>切换相机模式</span>
<a-button>抢夺负载控制</a-button> <a-button>抢夺负载控制</a-button>
</div> --> </div> -->
<div class="content-item"> <!-- <div class="content-item">
<span>拍照</span> <span>拍照</span>
<a-button @click="singleShot">单拍</a-button> <a-button @click="singleShot">单拍</a-button>
</div> </div> -->
<div class="content-button"> <div class="content-button">
<a-button @click="obtain">获取相机控制权</a-button>
<a-button @click="singleShot">单拍</a-button>
<a-button @click="enterDRC">进入飞行控制</a-button> <a-button @click="enterDRC">进入飞行控制</a-button>
<a-button @click="exitDRC">退出飞行控制</a-button> <a-button @click="exitDRC">退出飞行控制</a-button>
</div> </div>
@ -47,20 +49,38 @@
</template> </template>
<script setup lang="ts"> <script setup lang="ts">
import { onMounted, ref, watch, reactive, onUnmounted } from 'vue'; import { onMounted, ref, watch, reactive, onUnmounted } from 'vue';
import { getClient, createConnection } from '@/utils/mqtt'; import { getClient, createSeizeConnection, destroySeizeConnection } from '@/utils/mqtt';
import { CloseOutlined } from '@ant-design/icons-vue'; import { CloseOutlined } from '@ant-design/icons-vue';
import { vDrag } from '@/utils/drag'; import { vDrag } from '@/utils/drag';
import { buildGUID } from '@/utils/uuid'; import { buildGUID } from '@/utils/uuid';
import { servicesTopic, services_replyTopic } from '@/utils/debugging/remote'; import { servicesTopic, services_replyTopic } from '@/utils/debugging/remote';
import { drcDownTopicReize, eventsTopicSubscribeReize } from '@/utils/debugging/events'; import {
drcDownTopicReize,
eventsTopicSubscribeReize,
eventsTopicReize,
} from '@/utils/debugging/events';
import { useMessage } from '@/hooks/web/useMessage'; import { useMessage } from '@/hooks/web/useMessage';
import {
getRedisUser,
addOrUpdateRedisUser,
getLockedClients,
} from '@/api/workmanagement/airportMaintenance';
import { useUserStore } from '@/store/modules/user';
import { timestampToFormattedDate } from '@/utils/index';
const userStore = useUserStore();
const userInfo = userStore.getUserInfo;
const redisUser = ref({});
const { createMessage } = useMessage(); const { createMessage } = useMessage();
const emits = defineEmits(['changeLoadControl']); const emits = defineEmits(['changeLoadControl']);
const props = defineProps({ const props = defineProps({
msgData: Object, msgData: Object,
}); });
console.log(props); console.log(props);
// 是否飞行控制权抢夺
const flightGrab = ref(false);
// 是否进入飞行指令控制模式
const modeEnter = ref(false);
const drcVal = reactive({ const drcVal = reactive({
roll: 1024, roll: 1024,
pitch: 1024, pitch: 1024,
@ -90,35 +110,62 @@
} }
}, },
); );
//修改redis用户锁
const changeRedisUser = (val: boolean) => {
const querys = redisUser.value;
querys.isLock = val;
querys.connectTime = timestampToFormattedDate(new Date().getTime());
addOrUpdateRedisUser(querys);
};
const isLocked = ref(false);
// 判断有没有redis用户锁
const lockedClient = () => {
getLockedClients().then((res) => {
console.log(res);
if (res.length > 0) {
res.forEach((item, index) => {
if (item.userId != userInfo.id) {
isLocked.value = true;
}
});
}
});
};
const obtain = () => { const obtain = () => {
if (!getClient()) { // if (!getClient()) {
createConnection(); // createConnection();
// }
if (isLocked.value) {
createMessage.success('当前有用户正在操作，请稍后再试');
return;
} }
setTimeout(() => { changeRedisUser(true);
// 飞行控制权抢夺 // 飞行控制权抢夺
servicesTopic({ servicesTopic({
bid: buildGUID(), bid: buildGUID(),
method: 'flight_authority_grab', method: 'flight_authority_grab',
tid: buildGUID(), tid: buildGUID(),
timestamp: new Date().getTime(), timestamp: new Date().getTime(),
data: {}, data: {},
}); });
// 负载控制权抢夺 // 负载控制权抢夺
servicesTopic({ servicesTopic({
bid: buildGUID(), bid: buildGUID(),
method: 'payload_authority_grab', method: 'payload_authority_grab',
tid: buildGUID(), tid: buildGUID(),
timestamp: new Date().getTime(), timestamp: new Date().getTime(),
data: { data: {
payload_index: '99-0-0', payload_index: '99-0-0',
}, },
}); });
services_replyTopic(); services_replyTopic();
}, 1000);
}; };
// 单拍 // 单拍
const singleShot = () => { const singleShot = () => {
if (!flightGrab.value) {
createMessage.warning('请先获取相机控制权');
return;
}
// 开始拍照 // 开始拍照
eventsTopicReize({ eventsTopicReize({
bid: buildGUID(), bid: buildGUID(),
@ -132,6 +179,11 @@
}; };
const drcSeq = ref(1); const drcSeq = ref(1);
const enterDRC = () => { const enterDRC = () => {
if (!flightGrab.value) {
createMessage.warning('请先获取相机控制权');
return;
}
createSeizeConnection();
// 进入指令飞行控制模式 // 进入指令飞行控制模式
const querys = { const querys = {
bid: buildGUID(), bid: buildGUID(),
@ -185,26 +237,70 @@
}; };
servicesTopic(querys); servicesTopic(querys);
}; };
const seq = ref(1);
// 控制方向 // 控制方向
const changeDrc = (type, val) => { const changeDrc = (type, val) => {
if (!modeEnter.value) {
createMessage.warning('请先进入指令飞行控制');
return;
}
seq.value = seq.value + 1;
if (val == 'up') { if (val == 'up') {
drcVal[type] = drcVal[type] + 20; if (drcVal[type] < 1684) {
drcVal[type] = drcVal[type] + 20;
}
} else { } else {
drcVal[type] = drcVal[type] - 20; if (drcVal[type] > 364) {
drcVal[type] = drcVal[type] - 20;
}
} }
const querys = { const querys = {
seq: 1, seq: seq.value,
method: 'stick_control', method: 'stick_control',
data: drcVal, data: drcVal,
}; };
drcDownTopicReize(querys); drcDownTopicReize(querys);
}; };
onMounted(() => { onMounted(() => {
// 获取mqtt客户端信息
getRedisUser(userInfo.id).then((res) => {
console.log(res);
if (res) {
redisUser.value = res;
}
});
lockedClient();
// // 接收消息 // // 接收消息
getClient().on('message', (topic, message) => { getClient().on('message', (topic, message) => {
const rs = JSON.parse(message); const rs = JSON.parse(message);
if (rs.method == 'takeoff_to_point') { if (rs.method == 'flight_authority_grab') {
console.log(rs); console.log(rs);
if (rs.data.result == 0) {
flightGrab.value = true;
createMessage.success('飞行控制权抢夺成功');
} else {
flightGrab.value = false;
createMessage.error('飞行控制权抢夺失败，状态码' + rs.data.result);
}
}
if (rs.method == 'drc_mode_enter') {
console.log(rs);
if (rs.data.result == 0) {
modeEnter.value = true;
createMessage.success('进入指令飞行控制模式成功');
} else {
modeEnter.value = false;
createMessage.error('进入指令飞行控制模式失败，状态码' + rs.data.result);
}
}
if (rs.method == 'drc_mode_exit') {
console.log(rs);
if (rs.data.result == 0) {
modeEnter.value = false;
createMessage.success('退出指令飞行控制模式成功');
} else {
createMessage.error('退出指令飞行控制模式失败，状态码' + rs.data.result);
}
} }
if (rs.method === 'drc_status_notify') { if (rs.method === 'drc_status_notify') {
console.log(rs); console.log(rs);
@ -220,6 +316,8 @@
}); });
onUnmounted(() => { onUnmounted(() => {
window.clearInterval(timer); window.clearInterval(timer);
destroySeizeConnection();
changeRedisUser(false);
}); });
</script> </script>
<style lang="less" scoped> <style lang="less" scoped>
@ -287,6 +385,7 @@
} }
.direction-controller { .direction-controller {
position: relative; position: relative;
margin-top: 20px;
img { img {
margin-left: 60px; margin-left: 60px;
width: 200px; width: 200px;

2
src/views/demo/workmanagement/flightoperation/src/UAVInformation.vue
View File

@ -12,7 +12,7 @@
<div class="content"> <div class="content">
<div class="content-title"> <div class="content-title">
{{ time }} {{ time }}
<span>临近或已接近夜晚</span> <!-- <span>临近或已接近夜晚</span> -->
</div> </div>
<div class="content-item"> <div class="content-item">
<div class="item-div"> <div class="item-div">