机场直播初始化直接开启直播修改

src/packages/components/Zhigan/Zhigan/ZhiGan_AirportLive/index.vue

@@ -39,6 +39,8 @@
   import {
     getClient,
     createConnection,
+    clientPublish,
+    clientSubscribe
   } from '@/utils/mqtt';
   import {
     servicesTopic,
@@ -87,7 +89,9 @@ import { message } from 'ant-design-vue';
     EventBus.on(props.chartConfig.id + 'dataupdate', (data) => {
       console.log('data',data)
     });
-    
+    if (!getClient() || !getClient().connected) {
+      createConnection();
+    }
     setTimeout(() => {
       startLiveFun()
       player = TCPlayer('player-airport-live', {
@@ -143,8 +147,10 @@ import { message } from 'ant-design-vue';
       },
     };
     console.log(querys);
-    servicesTopic(querys);
-    services_replyTopic();
+    let getGateway = airPortStoreVal.getAirport.video_id.split('/')[0]
+    console.log('getGateway',getGateway)
+    clientPublish('thing/product/' + getGateway + '/services', querys);
+    clientSubscribe('thing/product/' + getGateway + '/services_reply');
   };
 </script>