socket优化

app.js

@@ -1,61 +1,58 @@
 import {
-    ApiModel
+  ApiModel
 } from './utils/api';
 
 App({
-    onLaunch(options) {
-        //小程序跳转进入
-        if (options.query.userMsg) {
-            wx.setStorageSync('userMsg', JSON.parse(options.query.userMsg));
-            wx.setStorageSync('auth', JSON.parse(options.query.auth));
-            wx.setStorageSync('siteP', JSON.parse(options.query.site));
-            //获取用户权限 
-            this.globalData.http.basic({
-                "classname": "sysmanage.develop.userauth.userauth",
-                "method": "query_userauth",
-                content: {
-                    nocache: true
-                }
-            }).then(res => {
-                console.log("跳转进入查询权限", res)
-                if (res.msg != '成功') return wx.showToast({
-                    title: '权限查询失败，请稍后再试',
-                    icon: "none"
-                })
-                wx.setStorageSync('userauth', res.data);
-            });
+  onLaunch(options) {
+    //小程序跳转进入
+    if (options.query.userMsg) {
+      wx.setStorageSync('userMsg', JSON.parse(options.query.userMsg));
+      wx.setStorageSync('auth', JSON.parse(options.query.auth));
+      wx.setStorageSync('siteP', JSON.parse(options.query.site));
+      //获取用户权限 
+      this.globalData.http.basic({
+        "classname": "sysmanage.develop.userauth.userauth",
+        "method": "query_userauth",
+        content: {
+          nocache: true
         }
-    },
-    initSocket() {
-        let that = this;
-        this.globalData.SocketTask = wx.connectSocket({
-            url: 'wss://oms.idcgroup.com.cn:8079/yos/webSocket/' + wx.getStorageSync('userMsg').token,
-            complete: (res) => {
-                console.log(res)
-            }
+      }).then(res => {
+        console.log("跳转进入查询权限", res)
+        if (res.msg != '成功') return wx.showToast({
+          title: '权限查询失败，请稍后再试',
+          icon: "none"
         })
-        this.globalData.SocketTask.onOpen(function (res) {
-            that.globalData.socketEstablish = true;
-        })
-        this.globalData.SocketTask.onMessage(function (res) {
-            that.globalData.socket.callback(res)
-        })
-        this.globalData.SocketTask.onError(function (res) {
-            that.globalData.socketEstablish = false;
-        })
-        this.globalData.SocketTask.onClose(function (res) {
-            that.globalData.socketEstablish = false;
-        })
-    },
-    globalData: {
-        http: new ApiModel(), //接口文件
-        queryPer: require("./utils/queryPermissions"), //权限查询
-        socketEstablish: false, //是否已经建立socket
-        SocketTask: '', // Socket方法
-        socket: { // Socket回调
-            that: null, //保存this
-            callback: function () {}
-        },
-        handleSelect: null, //处理选择结果  函数
-    },
+        wx.setStorageSync('userauth', res.data);
+      });
+    }
+  },
+  initSocket() {
+    let that = this;
+    this.globalData.SocketTask = wx.connectSocket({
+      url: 'wss://oms.idcgroup.com.cn:8079/yos/webSocket/' + wx.getStorageSync('userMsg').token,
+      complete: (res) => {
+        console.log(res)
+      }
+    })
+    this.globalData.SocketTask.onOpen(function (res) {
+      that.globalData.socketEstablish = true;
+    })
+    this.globalData.SocketTask.onMessage(function (res) {
+      that.globalData.socketCallback(res)
+    })
+    this.globalData.SocketTask.onError(function (res) {
+      that.globalData.socketEstablish = false;
+    })
+    this.globalData.SocketTask.onClose(function (res) {
+      that.globalData.socketEstablish = false;
+    })
+  },
+  globalData: {
+    http: new ApiModel(), //接口文件
+    queryPer: require("./utils/queryPermissions"), //权限查询
+    socketEstablish: false, //是否已经建立socket
+    SocketTask: '', // Socket方法
+    socketCallback: null, // Socket回调
+    handleSelect: null, //处理选择结果  函数
+  },
 })