websocket初体验（小程序）

Posted 2022-05-19 visiliki-lvy

之前上个公司做过一个二维码付款功能，涉及到websocket功能，直接上代码

小程序onShow方法下加载：

/**  页面的初始数据 **/
 data: 
    code: "",
    onshowCode: "",
    hiden: true,
    show: false,
    array: ,
    has_password: "",
    openid: "",
    showPop: false,
    pwd: "",
    num: "",
    cashierid: "",
    socketOpen: false
  ,
  onShow: function() 
    var _this = this;
    a.get("ipass.get_user_qr", , function(e) 
//获取到openID（传的参数）      
      console.log(e);
      var openid = e.openid;
      console.log(openid);
      _this.setData(
        array: e,
        openid: openid
      );
      var token = _this.data.openid;
      var socketOpen = false;
      var data =  type: "ready", uid: token ;   // 给websocket传值
      var socketMsgQueue = JSON.stringify(data);   // 将值转化为字符串
      // 连接websocket
      wx.connectSocket(
        url: "wss://paytest.kuaiyunma.com",    //websocket 地址
        success(e) 
          console.log(e);
        
      );
      // 监听WebSocket 连接打开事件
      wx.onSocketOpen(function(res) 
        console.log("123");
        _this.data.socketOpen = true; 
        console.log("数据发送中" + socketMsgQueue);
        _this.sendSocketMessage(socketMsgQueue);  // 自定义方法
      );
      // 监听WebSocket 错误事件
      wx.onSocketError(function(res) 
        console.log("WebSocket连接打开失败，请检查！");
      );
      // 监听WebSocket 接受到服务器的消息事件
      wx.onSocketMessage(function(res) 
        console.log(JSON.parse(res.data));
//获取到websocket返回的值
        var res = JSON.parse(res.data);
//将值转化为对象
        var num = res.fee;
//定义传过来的数值
        var cashierid = res.cashierid;
// 根据传的值进行判断    
        if (res.type == "password") 
          _this.setData(
            showPop: true,
            num: num,
            res: res,
            cashierid: cashierid
          );
         else if (res.type == "pay_result") 
          if (res.result == "ok") 
            a.post(
              "ipass.pay",
              
                cashierid: _this.data.cashierid,
                money: _this.data.num
              ,
              function(e) 
                console.log(e);
                if (e.result.success === true) 
                  wx.showToast(
                    title: "支付成功！",
                    icon: "success"
                  );
                 else 
                  wx.showToast(
                    title: "支付失败",
                    icon: "none"
                  );
                
                _this.clearNum();
              
            );
           else 
            wx.showToast(
              title: "支付失败",
              icon: "none"
            );
          
        
      );
    );
  ,
//设置公共传值的方法~~
  sendSocketMessage: function(msg) 
    var socketOpen = this.data.socketOpen;
    if (socketOpen) 
      wx.sendSocketMessage(
        data: msg,
        success(e) 
          console.log(e);
        
      );
    
  ,
  inputPwd(e) 
    console.log(e);
    var pwd = e.target.dataset.value;
    let rule = /[0-9]/;
    if (!rule.test(pwd)) 
      return;
    
    pwd = this.data.pwd + pwd;
    console.log(pwd);
    this.setData(
      pwd: pwd
    );
    var _this = this;
    if (pwd.toString().length == 6) 
      wx.showLoading(
        title: "支付中...",
        mask: true
      );
      console.log("成功");
      a.post(
        "ipass.password.auth",
        
          password: _this.data.pwd
        ,
        function(e) 
          console.log(e);
          wx.hideLoading();
          // var socketOpen = true;
          // 定义传的data值
          var data1 = 
            type: "validate_password",
            token: _this.data.res.token,
            cashierid: _this.data.res.cashierid,
            password: _this.data.pwd
          ;
          // 将转换的对象转换为字符串
          var socketMsgQueue1 = JSON.stringify(data1);
          if (!e.auth) 
            _this.setData(
              showPop: false,
              pwd: ""
            );
            wx.showToast(
              title: "支付密码错误",
              icon: "none"
            );
           else 
            // 发送socket信息
            _this.sendSocketMessage(socketMsgQueue1);

            _this.setData(
              showPop: false,
              pwd: ""
            );
          
        
      );
      setTimeout(() => 
        wx.hideLoading(
          success: function() 
            _this.setData(
              showPop: false,
              hasPaid: true
            );
          
        );
      , 2000);
    
  ,