微信小程序

.eslintrc.js

@@ -0,0 +1,31 @@
+/*
+ * Eslint config file
+ * Documentation: https://eslint.org/docs/user-guide/configuring/
+ * Install the Eslint extension before using this feature.
+ */
+module.exports = {
+  env: {
+    es6: true,
+    browser: true,
+    node: true,
+  },
+  ecmaFeatures: {
+    modules: true,
+  },
+  parserOptions: {
+    ecmaVersion: 2018,
+    sourceType: 'module',
+  },
+  globals: {
+    wx: true,
+    App: true,
+    Page: true,
+    getCurrentPages: true,
+    getApp: true,
+    Component: true,
+    requirePlugin: true,
+    requireMiniProgram: true,
+  },
+  // extends: 'eslint:recommended',
+  rules: {},
+}

app.js

@@ -0,0 +1,239 @@
+// app.ts
+import mqtt from './utils/mqtt';
+//连接的服务器域名
+// const host = 'wxs://mqtt.test.radio1964.com';
+// const host = 'wxs://mqtt.test.radio1964.com:8884';
+const host = 'wxs://mqtt.ssl.keepradioon.net:8884'
+App({
+  globalData: {
+    statusBarHeight: 0,
+    navBarHeight: 0,
+    MenuButtonheight: 0,
+    MenuButtonTop: 0,
+    scopeBluetooth: true,
+    ssid: "",
+    pwdData: "",
+    userData: null,
+    userInfo: null,
+    newDeviceId: null, 
+    is_debug: 2, // 1 测试环境 // 2正式环境
+    client: null,
+    oneInitBluetooth: true,
+    //MQTT连接的配置
+    options: {
+      clientId: "wx_" + parseInt(Math.random() * 100 + 800, 10),
+      reconnectPeriod: 1000, //1000毫秒，两次重新连接之间的间隔
+      connectTimeout: 30 * 1000, //1000毫秒，两次重新连接之间的间隔
+      resubscribe: true, //如果连接断开并重新连接，则会再次自动订阅已订阅的主题（默认true
+      keepalive: 3,//每3秒发送一次心跳
+    },
+  },
+  /**
+   * 连接设备
+   * mqttCallback：mqtt回调统一方法
+   */
+  connect() {
+    this.globalData.client = mqtt.connect(host, this.globalData.options);
+    // 连接成功
+    this.globalData.client.on('connect', ()=> {
+      const pageinfo = getCurrentPages()[getCurrentPages().length - 1];
+      if(pageinfo.mqttCallback) {
+        pageinfo.mqttCallback("connect")
+      };
+      
+    });
+    // 接收消息
+    this.globalData.client.on("message", function(topic, payload) {
+      wx.hideLoading();
+      const pageinfo = getCurrentPages()[getCurrentPages().length - 1];
+      const thisPageIsIndex = getCurrentPages().length === 1;
+      if(pageinfo.mqttCallback) {
+        if(topic.indexOf("status/onoffline") !== -1) {
+          pageinfo.mqttCallback("message_onoffline", {topic, payload});
+          if(!thisPageIsIndex) {
+            getCurrentPages()[0].mqttCallback("message_onoffline", {topic, payload})
+          }
+        } else if(topic.indexOf("user/pub_response") !== -1) {
+          pageinfo.mqttCallback("message", {topic, payload});
+        }
+      };
+    });
+    //服务器连接异常的回调
+    this.globalData.client.on("error", function(error) {
+      console.log(" 服务器 error 的回调" + error)
+      const pageinfo = getCurrentPages()[getCurrentPages().length - 1];
+      if(pageinfo.mqttCallback) {
+        pageinfo.mqttCallback("error")
+      };
+    })
+
+    // 服务器重连
+    this.globalData.client.on("reconnect", function(errr) {
+      console.log(" 服务器 reconnect的回调", errr);
+      const pageinfo = getCurrentPages()[getCurrentPages().length - 1];
+      if(pageinfo.mqttCallback) {
+        pageinfo.mqttCallback("reconnect")
+      };
+    })
+    //服务器断开连接
+    this.globalData.client.on("offline", function(errr) {
+      console.log(" 服务器 offline的回调", errr)
+      const pageinfo = getCurrentPages()[getCurrentPages().length - 1];
+      if(pageinfo.mqttCallback) {
+        pageinfo.mqttCallback("offline")
+      };
+    })
+  },
+
+
+
+  // 订阅主题
+  subscribe: function(topic, callback) {
+
+    if (this.globalData.client && this.globalData.client.connected) {
+      //订阅主题
+      this.globalData.client.subscribe(topic, function(err, granted) {
+        if (!err) {
+          if(callback) {
+            callback();
+          }
+          console.log("订阅成功");
+        } else {
+          console.log('订阅主题失败');
+        }
+      })
+    } else {
+      console.log("服务器已断开");
+      // wx.showToast({
+      //   title: '服务器已断开',
+      //   icon: 'error',
+      //   duration: 2000
+      // })
+    }
+  },
+  // 取消订阅
+  unsubscribe: function(Topic) {
+    if (this.globalData.client && this.globalData.client.connected) {
+      this.globalData.client.unsubscribe(Topic);
+    } else {
+      console.log('请先连接服务器');
+      // wx.showToast({
+      //   title: '请先连接服务器',
+      //   icon: 'none',
+      //   duration: 2000
+      // })
+    }
+  },
+
+  /**
+   * 发布信息
+   * @param {*} data
+   * DstDeviceName：目标设备
+   * type: 指令
+   * other：other
+   * .......................
+   * AIrSMArT_: 设备前缀
+   */
+  PubMsg(option, callback) {
+    if (this.globalData.client && this.globalData.client.connected) {
+      wx.showLoading({
+        title: '请稍后',
+      });
+      const data = {"DstDeviceName": option.DstDeviceName,"SrcDeviceName": `ALY_${this.globalData.userInfo.userId}`,"type": option.type};
+      if(option.other) {
+        data.other = option.other;
+      };
+      this.globalData.client.publish(`/${option.DstDeviceName}/user/sub_control`, `${JSON.stringify(data)}`,(err) => {
+        if (err) {
+          console.log("发布消息失败");
+        }
+      });
+    } else {
+      console.log("服务器已断开");
+      // wx.showToast({
+      //   title: '服务器已断开',
+      //   icon: 'error',
+      //   duration: 2000
+      // })
+    }
+  },
+  onLaunch() {
+    var _this = this;
+    wx.onAppHide(()=> {
+      if(_this.globalData.client && _this.globalData.client.connected){
+        _this.globalData.client.end(true);
+        _this.globalData.client.end(true);
+        console.log("断开");
+      };
+    });
+
+    wx.onAppShow(()=> {
+      console.log("加载")
+      if(_this.globalData.userInfo !== null){
+        if(_this.globalData.client) {
+          _this.globalData.client.end(true);
+          _this.globalData.client.end(true);
+        }
+        console.log("重连");
+        _this.connect();
+      };
+    });
+    this.getBluetoothStatus();
+    //自定义导航栏 获取设备顶部窗口的高度（不同设备窗口高度不一样，根据这个来设置自定义导航栏的高度）
+    wx.getSystemInfo({
+      success: (res) => {
+        let custom = wx.getMenuButtonBoundingClientRect();
+       
+        _this.globalData.navBarHeight = res.statusBarHeight + custom.height + (custom.top - res.statusBarHeight) * 2;
+        _this.globalData.MenuButtonheight = custom.height;
+        _this.globalData.MenuButtonTop = custom.top;
+        
+      }
+      
+    })
+  },
+  // 获取蓝牙权限
+  getBluetoothStatus(){
+    const _this = this;
+    wx.getSetting({
+      success (res) {
+        if(res.authSetting["scope.bluetooth"]) {
+          _this.globalData.scopeBluetooth = true;
+        } else if(res.authSetting["scope.bluetooth"] === undefined) {
+          _this.globalData.scopeBluetooth = false;
+          wx.authorize({ 
+            scope: "scope.bluetooth",
+            complete () {
+              _this.getBluetoothStatus();
+            }
+          });
+        } else {
+          _this.globalData.scopeBluetooth = false;
+          wx.showModal({
+            title: '请打开系统蓝牙进行配网',
+            content: '如已打开蓝牙仍然弹框，请尝试重启小程序',
+            success (res) {
+              if (res.confirm) {
+                console.log('用户点击确定')
+                wx.openSetting({
+                  complete () {
+                    // _this.getBluetoothStatus();
+                  }
+                })
+              } else if (res.cancel) {
+                console.log('用户点击取消')
+              }
+            }
+          })
+        };
+        if(getCurrentPages()[getCurrentPages().length - 1].getBluetoothStatusCallck) {
+          getCurrentPages()[getCurrentPages().length - 1].getBluetoothStatusCallck(_this.globalData.scopeBluetooth);
+        }
+        // res.authSetting = {
+        //   "scope.userInfo": true,
+        //   "scope.userLocation": true
+        // }
+      }
+    })
+  },
+})

app.json

@@ -0,0 +1,54 @@
+{
+  "pages": [
+    "pages/index/index",
+    "pages/login/login",
+    "pages/about/about",
+    "pages/repeat/repeat",
+    "pages/deviceWake/deviceWake",
+    "pages/channelDetails/channelDetails",
+    "pages/deviceConnect3/deviceConnect3",
+    "pages/deviceConnect0/deviceConnect0",
+    "pages/deviceConnect2/deviceConnect2",
+    "pages/deviceConnect1/deviceConnect1",
+    "pages/me/me",
+    "pages/download/download",
+    "pages/wakeList/wakeList",
+    "pages/aboutInfo/aboutInfo"
+  ],
+  "tabBar": {
+    "borderStyle": "black",
+    "list": [
+      {
+        "pagePath": "pages/index/index",
+        "text": "首页",
+        "iconPath": "./img/index_unaction.png",
+        "selectedIconPath": "./img/index_action.png"
+      },
+      {
+        "pagePath": "pages/me/me",
+        "text": "我的",
+        "iconPath": "./img/me_unaction.png",
+        "selectedIconPath": "./img/me_action.png"
+      }
+    ]
+  },
+  "window": {
+    "backgroundTextStyle": "light",
+    "navigationBarBackgroundColor": "#fff",
+    "backgroundColor": "#fff",
+    "navigationBarTitleText": "Weixin",
+    "navigationBarTextStyle": "black",
+    "navigationStyle": "custom"
+  },
+  "networkTimeout": {
+    "request": 20000,
+    "connectSocket": 20000,
+    "uploadFile": 20000,
+    "downloadFile": 20000
+  },
+  "style": "v2",
+  "sitemapLocation": "sitemap.json",
+  "requiredPrivateInfos": [
+    "getFuzzyLocation"
+  ]
+}

app.wxss

@@ -0,0 +1,79 @@
+.deviceRoter .roterps {
+  padding: 0 66rpx;
+}
+
+.deviceRoter .roterps .devicePic {
+  padding: 100rpx 0 50rpx;
+  display: flex;
+  justify-content: center;
+}
+
+.deviceRoter .roterps .devicePic image {
+  width: 512rpx;
+}
+
+.deviceRoter .roterps > text {
+  font-size: 32rpx;
+  color: #353533;
+  line-height: 44rpx;
+}
+
+.deviceRoter .roterps .qx {
+  margin-top: 24rpx;
+  display: flex;
+  height: 44rpx;
+  align-items: center;
+}
+
+.deviceRoter .roterps .qx text {
+  font-size: 32rpx;
+  color: #6547A3;
+  line-height: 44rpx;
+  font-weight: bold;
+}
+
+.deviceRoter .roterps .qx image {
+  height: 28rpx;
+  margin-left: 20rpx;
+}
+
+.deviceRoter .subBtn {
+  position: absolute;
+  bottom: 60rpx;
+  left: 0;
+  width: 100vw;
+  display: flex;
+  justify-content: center;
+  flex-direction: column;
+  align-items: center;
+}
+
+.deviceRoter .subBtn .btn {
+  width: 520rpx;
+  height: 80rpx;
+  background: #6547A3;
+  border-radius: 45rpx;
+  display: flex;
+  justify-content: center;
+  align-items: center;
+  font-size: 36rpx;
+  color: #fff;
+}
+
+.deviceRoter .subBtn .notRoter {
+  margin-top: 24rpx;
+  display: flex;
+  height: 44rpx;
+  align-items: center;
+}
+
+.deviceRoter .subBtn .notRoter text {
+  font-size: 24rpx;
+  color: #353535;
+  line-height: 44rpx;
+}
+
+.deviceRoter .subBtn .notRoter image {
+  height: 20rpx;
+  margin-left: 20rpx;
+}

common/main.wxss

@@ -0,0 +1,17 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+/*每个页面公共css */
+

common/runtime.js

@@ -0,0 +1,158 @@
+
+  !function(){try{var a=Function("return this")();a&&!a.Math&&(Object.assign(a,{isFinite:isFinite,Array:Array,Date:Date,Error:Error,Function:Function,Math:Math,Object:Object,RegExp:RegExp,String:String,TypeError:TypeError,setTimeout:setTimeout,clearTimeout:clearTimeout,setInterval:setInterval,clearInterval:clearInterval}),"undefined"!=typeof Reflect&&(a.Reflect=Reflect))}catch(a){}}();
+  /******/ (function(modules) { // webpackBootstrap
+/******/ 	// install a JSONP callback for chunk loading
+/******/ 	function webpackJsonpCallback(data) {
+/******/ 		var chunkIds = data[0];
+/******/ 		var moreModules = data[1];
+/******/ 		var executeModules = data[2];
+/******/
+/******/ 		// add "moreModules" to the modules object,
+/******/ 		// then flag all "chunkIds" as loaded and fire callback
+/******/ 		var moduleId, chunkId, i = 0, resolves = [];
+/******/ 		for(;i < chunkIds.length; i++) {
+/******/ 			chunkId = chunkIds[i];
+/******/ 			if(Object.prototype.hasOwnProperty.call(installedChunks, chunkId) && installedChunks[chunkId]) {
+/******/ 				resolves.push(installedChunks[chunkId][0]);
+/******/ 			}
+/******/ 			installedChunks[chunkId] = 0;
+/******/ 		}
+/******/ 		for(moduleId in moreModules) {
+/******/ 			if(Object.prototype.hasOwnProperty.call(moreModules, moduleId)) {
+/******/ 				modules[moduleId] = moreModules[moduleId];
+/******/ 			}
+/******/ 		}
+/******/ 		if(parentJsonpFunction) parentJsonpFunction(data);
+/******/
+/******/ 		while(resolves.length) {
+/******/ 			resolves.shift()();
+/******/ 		}
+/******/
+/******/ 		// add entry modules from loaded chunk to deferred list
+/******/ 		deferredModules.push.apply(deferredModules, executeModules || []);
+/******/
+/******/ 		// run deferred modules when all chunks ready
+/******/ 		return checkDeferredModules();
+/******/ 	};
+/******/ 	function checkDeferredModules() {
+/******/ 		var result;
+/******/ 		for(var i = 0; i < deferredModules.length; i++) {
+/******/ 			var deferredModule = deferredModules[i];
+/******/ 			var fulfilled = true;
+/******/ 			for(var j = 1; j < deferredModule.length; j++) {
+/******/ 				var depId = deferredModule[j];
+/******/ 				if(installedChunks[depId] !== 0) fulfilled = false;
+/******/ 			}
+/******/ 			if(fulfilled) {
+/******/ 				deferredModules.splice(i--, 1);
+/******/ 				result = __webpack_require__(__webpack_require__.s = deferredModule[0]);
+/******/ 			}
+/******/ 		}
+/******/
+/******/ 		return result;
+/******/ 	}
+/******/
+/******/ 	// The module cache
+/******/ 	var installedModules = {};
+/******/
+/******/ 	// object to store loaded and loading chunks
+/******/ 	// undefined = chunk not loaded, null = chunk preloaded/prefetched
+/******/ 	// Promise = chunk loading, 0 = chunk loaded
+/******/ 	var installedChunks = {
+/******/ 		"common/runtime": 0
+/******/ 	};
+/******/
+/******/ 	var deferredModules = [];
+/******/
+/******/ 	// The require function
+/******/ 	function __webpack_require__(moduleId) {
+/******/
+/******/ 		// Check if module is in cache
+/******/ 		if(installedModules[moduleId]) {
+/******/ 			return installedModules[moduleId].exports;
+/******/ 		}
+/******/ 		// Create a new module (and put it into the cache)
+/******/ 		var module = installedModules[moduleId] = {
+/******/ 			i: moduleId,
+/******/ 			l: false,
+/******/ 			exports: {}
+/******/ 		};
+/******/
+/******/ 		// Execute the module function
+/******/ 		modules[moduleId].call(module.exports, module, module.exports, __webpack_require__);
+/******/
+/******/ 		// Flag the module as loaded
+/******/ 		module.l = true;
+/******/
+/******/ 		// Return the exports of the module
+/******/ 		return module.exports;
+/******/ 	}
+/******/
+/******/
+/******/ 	// expose the modules object (__webpack_modules__)
+/******/ 	__webpack_require__.m = modules;
+/******/
+/******/ 	// expose the module cache
+/******/ 	__webpack_require__.c = installedModules;
+/******/
+/******/ 	// define getter function for harmony exports
+/******/ 	__webpack_require__.d = function(exports, name, getter) {
+/******/ 		if(!__webpack_require__.o(exports, name)) {
+/******/ 			Object.defineProperty(exports, name, { enumerable: true, get: getter });
+/******/ 		}
+/******/ 	};
+/******/
+/******/ 	// define __esModule on exports
+/******/ 	__webpack_require__.r = function(exports) {
+/******/ 		if(typeof Symbol !== 'undefined' && Symbol.toStringTag) {
+/******/ 			Object.defineProperty(exports, Symbol.toStringTag, { value: 'Module' });
+/******/ 		}
+/******/ 		Object.defineProperty(exports, '__esModule', { value: true });
+/******/ 	};
+/******/
+/******/ 	// create a fake namespace object
+/******/ 	// mode & 1: value is a module id, require it
+/******/ 	// mode & 2: merge all properties of value into the ns
+/******/ 	// mode & 4: return value when already ns object
+/******/ 	// mode & 8|1: behave like require
+/******/ 	__webpack_require__.t = function(value, mode) {
+/******/ 		if(mode & 1) value = __webpack_require__(value);
+/******/ 		if(mode & 8) return value;
+/******/ 		if((mode & 4) && typeof value === 'object' && value && value.__esModule) return value;
+/******/ 		var ns = Object.create(null);
+/******/ 		__webpack_require__.r(ns);
+/******/ 		Object.defineProperty(ns, 'default', { enumerable: true, value: value });
+/******/ 		if(mode & 2 && typeof value != 'string') for(var key in value) __webpack_require__.d(ns, key, function(key) { return value[key]; }.bind(null, key));
+/******/ 		return ns;
+/******/ 	};
+/******/
+/******/ 	// getDefaultExport function for compatibility with non-harmony modules
+/******/ 	__webpack_require__.n = function(module) {
+/******/ 		var getter = module && module.__esModule ?
+/******/ 			function getDefault() { return module['default']; } :
+/******/ 			function getModuleExports() { return module; };
+/******/ 		__webpack_require__.d(getter, 'a', getter);
+/******/ 		return getter;
+/******/ 	};
+/******/
+/******/ 	// Object.prototype.hasOwnProperty.call
+/******/ 	__webpack_require__.o = function(object, property) { return Object.prototype.hasOwnProperty.call(object, property); };
+/******/
+/******/ 	// __webpack_public_path__
+/******/ 	__webpack_require__.p = "/";
+/******/
+/******/ 	var jsonpArray = global["webpackJsonp"] = global["webpackJsonp"] || [];
+/******/ 	var oldJsonpFunction = jsonpArray.push.bind(jsonpArray);
+/******/ 	jsonpArray.push = webpackJsonpCallback;
+/******/ 	jsonpArray = jsonpArray.slice();
+/******/ 	for(var i = 0; i < jsonpArray.length; i++) webpackJsonpCallback(jsonpArray[i]);
+/******/ 	var parentJsonpFunction = oldJsonpFunction;
+/******/
+/******/
+/******/ 	// run deferred modules from other chunks
+/******/ 	checkDeferredModules();
+/******/ })
+/************************************************************************/
+/******/ ([]);
+//# sourceMappingURL=../../.sourcemap/mp-weixin/common/runtime.js.map
+