处理 socket 问题

src/layouts/BasicLayout.vue

@@ -53,10 +53,8 @@
       <a-layout-footer>
         <global-footer />
       </a-layout-footer>
-
     </a-layout>
   </a-layout>
-
 </template>
 
 <script>
@@ -99,8 +97,8 @@ export default {
       return '80px'
     },
     placeholderDivMinWidth() {
-      let width = this.collapsed ? '80px' : '230px';
+      let width = this.collapsed ? '80px' : '230px'
-      return width;
+      return width
     }
   },
   watch: {
@@ -129,10 +127,22 @@ export default {
       })
     }
     console.log('== 1111进入页面 == ,这里添加获取订舱下拉数据 ')
-    this.setBookingInfo()
+    // this.setBookingInfo()
   },
   methods: {
-    ...mapActions(['setSidebar', 'setCarrierList', 'setYardList', 'setPackageList', 'setIssuetypeList', 'setBlfrtList', 'setCtnallList', 'setLineList', 'setBookingSourcePage', 'setBookingInitData', 'setCodeCountryList']),
+    ...mapActions([
+      'setSidebar',
+      'setCarrierList',
+      'setYardList',
+      'setPackageList',
+      'setIssuetypeList',
+      'setBlfrtList',
+      'setCtnallList',
+      'setLineList',
+      'setBookingSourcePage',
+      'setBookingInitData',
+      'setCodeCountryList'
+    ]),
     // 重新生成
     setMenus() {
       const routes = convertRoutes(this.mainMenu.find(item => item.path === '/'))
@@ -148,12 +158,11 @@ export default {
       if (this.sidebarOpened) {
         left = this.isDesktop() ? '230px' : '80px'
       } else {
-        left = (this.isMobile() && '0') || ((this.fixSidebar && '80px') || '0')
+        left = (this.isMobile() && '0') || (this.fixSidebar && '80px') || '0'
       }
       return left
     },
-    menuSelect () {
+    menuSelect() {},
-    },
     drawerClose() {
       this.collapsed = false
     },

src/main.js

@@ -29,7 +29,7 @@ import VXETable from 'vxe-table'
 import 'vxe-table/lib/style.css'
 import 'vue-easytable/libs/theme-default/index.css'
 import VueEasytable from 'vue-easytable'
-import qs from 'qs';
+import qs from 'qs'
 
 Vue.use(VXETable)
 Vue.use(VueContextMenu)
@@ -44,7 +44,7 @@ Vue.prototype.hasPerm = hasBtnPermission
 Vue.prototype.applocation = sysApplication
 Vue.prototype.$bus = new Vue()
 Vue.config.productionTip = false
-Vue.prototype.$qs = qs;
+Vue.prototype.$qs = qs
 
 new Vue({
   router,

src/utils/socket.js

@@ -46,45 +46,45 @@ class SocketConnection extends EventEmitter {
     }
   }
 
-  async start(token) {
+  // async start(token) {
-    // 组件重新加载时, 如果 socket 存在, 不需要新建
+  //   // 组件重新加载时, 如果 socket 存在, 不需要新建
-    if (!this.socket) {
+  //   if (!this.socket) {
-      this.socket = new SignalR.HubConnectionBuilder()
+  //     this.socket = new SignalR.HubConnectionBuilder()
-        .configureLogging(SignalR.LogLevel.Information)
+  //       .configureLogging(SignalR.LogLevel.Information)
-        .withUrl(
+  //       .withUrl(
-          `/hubs/chathub`, {
+  //         `/hubs/chathub`, {
-            accessTokenFactory: () => token,
+  //           accessTokenFactory: () => token,
-            skipNegotiation: true,
+  //           skipNegotiation: true,
-            transport: SignalR.HttpTransportType.WebSockets
+  //           transport: SignalR.HttpTransportType.WebSockets
-          }
+  //         }
-        )
+  //       )
-        .build()
+  //       .build()
-
+
-      this.socket.on('ForceExist', () => { //可以做相关业务逻辑
+  //     this.socket.on('ForceExist', () => { //可以做相关业务逻辑
-        store.dispatch("Logout").then(()=>{
+  //       store.dispatch("Logout").then(()=>{
-          window.location.reload()
+  //         window.location.reload()
-        }).catch(err=>{
+  //       }).catch(err=>{
-          this.$message.error({
+  //         this.$message.error({
-            title: '错误',
+  //           title: '错误',
-            description: err.message
+  //           description: err.message
-          })
+  //         })
-        })
+  //       })
-      })
+  //     })
-      
+
-      this.socket.on('AppendNotice', (notice) => { 
+  //     this.socket.on('AppendNotice', (notice) => {
-         store.commit("APPEND_NOTICE",notice)
+  //        store.commit("APPEND_NOTICE",notice)
-      })
+  //     })
-
+
-      this.socket.onclose(async () => {
+  //     this.socket.onclose(async () => {
-        this.offline = true
+  //       this.offline = true
-        this.emit('onclose')
+  //       this.emit('onclose')
-        await this._initialize()
+  //       await this._initialize()
-      })
+  //     })
-
+
-      await this._initialize()
+  //     await this._initialize()
-
+
-    }
+  //   }
-  }
+  // }
 
   async authenticate(token) {
     await this.start(token)
@@ -92,11 +92,11 @@ class SocketConnection extends EventEmitter {
 
   listen(method) {
     if (this.offline) return
-    if (this.listened.some((v) => v === method)) return
+    if (this.listened.some(v => v === method)) return
     this.listened.push(method)
     this.one('onstart', () => {
-      this.listened.forEach((method) => {
+      this.listened.forEach(method => {
-        this.socket.on(method, (data) => {
+        this.socket.on(method, data => {
           if (this.options.log) {
             console.log({
               type: 'receive',
@@ -143,7 +143,7 @@ class SocketConnection extends EventEmitter {
     }
 
     // eslint-disable-next-line no-async-promise-executor
-    return new Promise(async (resolve) => this.one('onstart', () => resolve(this.socket.invoke(methodName, ...args))))
+    return new Promise(async resolve => this.one('onstart', () => resolve(this.socket.invoke(methodName, ...args))))
   }
 }
 
@@ -173,16 +173,16 @@ function install(Vue, connection) {
       if (this.$options.sockets) {
         const methods = Object.getOwnPropertyNames(this.$options.sockets)
 
-        methods.forEach((method) => {
+        methods.forEach(method => {
           Socket.listen(method)
 
-          Socket.one(method, (data) => this.$options.sockets[method].call(this, data))
+          Socket.one(method, data => this.$options.sockets[method].call(this, data))
         })
       }
 
       if (this.$options.subscribe) {
         Socket.one('authenticated', () => {
-          this.$options.subscribe.forEach((channel) => {
+          this.$options.subscribe.forEach(channel => {
             Socket.invoke('join', channel)
           })
         })