网络请求，封装简化注释

api/login.js

@@ -0,0 +1,21 @@
+import request from '../utils/request'
+// 登录方法
+export function login(data) {
+  return request({
+    url: '/auth/app/login', // 假设登录接口是 /login
+    method: 'POST',
+    data: data
+  })
+}
+// 注册发送验证码
+export function sendRegisterSms(data) {
+  return request({
+    url: '/api/appUser/sendRegisterSms', //发送验证码注册
+    method: 'POST',
+    data: data
+  })
+}
+
+
+
+

pages/common/login/index.vue

@@ -53,6 +53,7 @@
 </template>
 
 <script>
+	import { login } from '@/api/login';
 	export default {
 		data() {
 			return {

utils/mqtt.js

@@ -1,41 +1,28 @@
-import mqtt from 'mqtt/dist/mqtt.js'; // 根据典型的 uniapp 结构调整路径
+import mqtt from 'mqtt/dist/mqtt.js';
 
-// 请替换为您的 MQTT代理（broker）详细信息
 const MQTT_BROKER_URL = 'ws://your-mqtt-broker-address:your-port/mqtt'; // 使用 ws:// 或 wss://
 const MQTT_OPTIONS = {
-    connectTimeout: 4000, // 连接超时时间 (毫秒)
-    clientId: `mqtt_client_${Math.random().toString(16).substr(2, 8)}`, // 唯一的客户端ID
-    username: 'your-username', // 用户名 (可选)
-    password: 'your-password', // 密码 (可选)
-    clean: true, // 对于大多数移动应用场景，建议为 true
-    // 更多选项请参考 MQTT.js 文档
-    // Keepalive (心跳包间隔) 通常为 30-60 秒。
-    // reconnectPeriod: 1000, // 每次重新连接尝试之间的间隔时间 (毫秒)
+    connectTimeout: 4000,
+    clientId: `mqtt_client_${Math.random().toString(16).substr(2, 8)}`,
+    username: 'your-username', 
+    password: 'your-password', 
+    clean: true, 
 };
 
-let client = null; // MQTT 客户端实例
-let connectPromise = null; // 用于跟踪连接过程的 Promise
+let client = null;
+let connectPromise = null; 
 
 // 连接到 MQTT 代理
 export function connect() {
-    // 如果客户端已存在并且已连接，则直接返回
     if (client && client.connected) {
         return Promise.resolve(client);
     }
-
-    // 如果正在连接中，则返回当前的连接 Promise
     if (connectPromise) {
         return connectPromise;
     }
 
     let url = MQTT_BROKER_URL;
     // #ifdef MP-WEIXIN || APP-PLUS
-    // 对于微信小程序和 App，某些代理可能需要 'wx://' 或 'wxs://'
-    // if (MQTT_BROKER_URL.startsWith('ws://')) {
-    //     url = MQTT_BROKER_URL.replace('ws://', 'wx://');
-    // } else if (MQTT_BROKER_URL.startsWith('wss://')) {
-    //     url = MQTT_BROKER_URL.replace('wss://', 'wxs://');
-    // }
     // #endif
 
     console.log(`正在连接到 MQTT 代理: ${url}`);
@@ -44,7 +31,7 @@ export function connect() {
     connectPromise = new Promise((resolve, reject) => {
         client.on('connect', () => {
             console.log('MQTT 已连接');
-            connectPromise = null; // 连接成功后清除 Promise
+            connectPromise = null;
             resolve(client);
         });
 
@@ -54,19 +41,14 @@ export function connect() {
 
         client.on('error', (err) => {
             console.error('MQTT 连接错误:', err);
-            if (connectPromise) { // 仅当是初始连接尝试时才 reject
+            if (connectPromise) { 
                 reject(err);
             }
-            connectPromise = null; // 出错时清除 Promise
-            // 如果合适，可以考虑在此处尝试断开连接或清理客户端
-            // client.end(true, () => console.log('客户端因错误被强制结束.'));
+            connectPromise = null; 
         });
 
         client.on('close', () => {
             console.log('MQTT 连接已关闭');
-            // 如果连接意外关闭，您可能需要将客户端置为 null
-            // 或设置一个标志，以便 `connect()` 可以尝试建立新连接。
-            // client = null; // 或者管理重连逻辑
             connectPromise = null;
         });
 
@@ -166,38 +148,31 @@ export function unsubscribe(topic) {
             });
         } else {
             console.warn('MQTT 客户端未连接，无法取消订阅。');
-            resolve(); // 或 reject，取决于期望的行为
+            resolve();
         }
     });
 }
 
 // 处理传入的消息
-// 连接后设置一次此回调至关重要。
 export function onMessage(callback) {
     if (client) {
         client.on('message', callback); // 回调格式: (topic, message, packet) => { ... }
     } else {
-        // 可能是 connect() 初始化 'client' 之前调用了此函数
-        // 延迟附加监听器，直到客户端可用。
         const checkClientInterval = setInterval(() => {
             if (client) {
                 client.on('message', callback);
                 clearInterval(checkClientInterval);
             } else if (connectPromise === null && client === null) {
-                 // 如果 connectPromise 为 null且 client 为 null，表示 connect() 未被调用或已永久失败。
                  console.warn('MQTT 客户端未初始化以处理 onMessage，且没有连接尝试正在进行中。');
                  clearInterval(checkClientInterval);
             }
-        }, 100); // 每 100 毫秒检查一次
+        }, 100);
     }
 }
-
-// 您可能希望直接公开客户端以用于高级用例或特定的事件处理
 export function getClient() {
     return client;
 }
 
-// 可选：添加一个函数来检查连接状态
 export function isConnected() {
     return client && client.connected;
 }

utils/request.js

@@ -1,72 +1,40 @@
 import axios from 'axios'
-// 如果使用 Vuex 且需要 token，请取消注释
-// import store from '@/store'
-// 示例：如果你有身份验证相关的工具函数
-// import { getToken } from '@/utils/auth'
-
+const BASE_URL = 'http://192.168.2.23:8000' 
 // 创建 Axios 实例
 const service = axios.create({
-  // 重要：请在此处配置你的 API 基础 URL
-  // 你可以从环境变量或配置文件中获取
-  baseURL: process.env.VUE_APP_BASE_API || '/api', // 示例基础 URL
-  timeout: 10000 // 请求超时时间 (毫秒)
+  baseURL: BASE_URL,
+  timeout: 10000
 })
-
 // 请求拦截器
 service.interceptors.request.use(
   config => {
-    // 如果需要，添加 Authorization 请求头
-    // 示例：检查用户是否登录（例如，通过 Vuex store 或 auth 工具函数）
-    // if (store.getters.token) {
-    //   // 根据你的认证方案调整
-    //   config.headers['Authorization'] = 'Bearer ' + getToken()
-    // }
+	   console.log('Full Request URL:', config.baseURL + config.url)
+    const token = uni.getStorageSync('token')
+    if (token) {
+
+      config.headers['Authorization'] = 'Bearer ' + token
+    }
     config.headers['Content-Type'] = config.headers['Content-Type'] || 'application/json';
     return config
   },
   error => {
-    // 处理请求错误
-    console.error('Request Error:', error) // 用于调试
+    console.log('Request Error:', error)
     return Promise.reject(error)
   }
 )
 
 // 响应拦截器
 service.interceptors.response.use(
-  /**
-   * 如果你想获取诸如头信息或状态之类的http信息
-   * 请返回  response => response
-  */
-
-  /**
-   * 通过自定义代码确定请求状态
-   * 这里只是一个例子
-   * 你也可以通过HTTP状态码判断状态
-   */
   response => {
     const res = response.data
-    // 示例：根据你的后端响应结构调整此部分
-    // 如果自定义状态码不是 200 (或你的成功状态码)，则判断为错误。
-    if (res.code !== 200 && res.code !== 0) { // 假设 200 或 0 表示成功
-       // 你可以在此添加全局错误处理，例如显示提示消息
-       // uni.showToast({ title: res.message || '错误', icon: 'none' });
-       console.error('API Error:', res.message || 'Error')
-
-      // 示例：处理特定的错误代码，例如未授权 (401)
-      // if (res.code === 401) {
-      //   // 例如：重定向到登录页面
-      // }
+    if (res.code !== 200 && res.code !== 0) { 
+       console.log('API Error:', res.message || 'Error')
       return Promise.reject(new Error(res.message || 'Error'))
     } else {
-      // 如果成功，则返回响应的数据部分
-      // 如果后端没有将数据包装在 'data' 字段中，请调整此项
-      return res.data     
+      return res
     }
   },
   error => {
-    console.error('Response Error:', error.message) // 用于调试
-    // 处理网络错误或其他错误
-    // uni.showToast({ title: error.message, icon: 'none' });
     return Promise.reject(error)
   }
 )