代客下单逻辑修改

http/websock copy.js

@@ -0,0 +1,155 @@
+import {
+	reactive,
+	ref
+} from 'vue';
+// WebSocket 工具类，封装了 WebSocket 的连接、发送、接收、心跳、重连和关闭等操作  
+class WebsocketUtil {
+
+	// 构造函数，初始化 WebSocket 连接  
+	constructor(url, time, params) {
+		this.url = url; // WebSocket 服务器的 URL  
+		this.params = params; // WebSocket 服务器的 URL  
+		this.time = time; // 心跳发送的间隔时间（秒） 
+		this.socketTask = null; // WebSocket 任务对象  
+		this.isOpen = false; // WebSocket 连接是否打开  
+		this.reconnectTimeout = null; // 重连定时器  
+		this.heartbeatInterval = null; // 心跳定时器  
+		this.messageCallbacks = []; // 存储外部注册的消息回调函数的数组  
+		this.messageCallbacks = []; // 存储外部注册的消息回调函数的数组  
+
+		// 初始化 WebSocket 连接  
+		this.initializeWebSocket();
+	}
+
+	// 初始化 WebSocket 连接    
+	initializeWebSocket() {
+		if (this.isOpen) {
+			return
+		}
+		this.socketTask = uni.connectSocket({
+			url: this.url,
+			success: () => {
+				console.log('WebSocket连接成功');
+				return this.socketTask;
+			},
+			fail: (error) => {
+				console.error('WebSocket连接失败', error);
+				uni.$emit('is-socket-open', true)
+				this.reconnect();
+			}
+		});
+
+		this.socketTask.onOpen((res) => {
+			console.log('WebSocket连接正常！==', res);
+			this.isOpen = true;
+			// 连接成功后启动心跳和消息监听
+			this.startHeartbeat();
+			this.listenForMessages();
+			uni.$emit('is-socket-open', true)
+
+		});
+		this.socketTask.onError((res) => {
+			console.log('WebSocket连接失败！==', res);
+			uni.$emit('is-socket-open', false)
+			this.reconnect();
+		});
+		// 注意：这里的 onClose 监听器应该放在 uni.connectSocket 调用之后
+		this.socketTask.onClose((result) => {
+			this.isOpen = false;
+			// if( this.isOpen ){
+			this.reconnect();
+			// }
+		});
+
+	}
+
+	// 启动心跳检测  
+	startHeartbeat() {
+		if (this.heartbeatInterval) {
+			clearInterval(this.heartbeatInterval);
+		}
+		this.heartbeatInterval = setInterval(() => {
+			if (this.isOpen) {
+				this.send(JSON.stringify({"type": "ping_interval","set": "pad"}));
+			}
+		}, this.time);
+	}
+
+	// 发送消息  
+	send(data, type) {
+		if (this.socketTask && this.isOpen) {
+			this.socketTask.send({
+				data: data,
+				success: (res) => {
+					// console.log('消息发送成功', res);  
+				},
+				fail: (error) => {
+					console.error('消息发送失败', error);
+					this.reconnect(); // 这里可能需要根据实际情况判断是否重连  
+				}
+			});
+		}
+	}
+
+	// 监听 WebSocket 消息  
+	listenForMessages() {
+		if (this.socketTask) {
+			this.socketTask.onMessage((res) => {
+				const {
+					data
+				} = res;
+				this.messageCallbacks.forEach(callback => callback(data
+					.toString())); // 假设 data 是字符串或可转换为字符串  
+			});
+			// this.send("WebSocket连接正常");
+		} else {
+			console.error('WebSocket 连接尚未建立，无法监听消息');
+		}
+	}
+
+	// 重连 WebSocket  
+	reconnect() {
+		if (this.reconnectTimeout) {
+			clearTimeout(this.reconnectTimeout);
+		}
+		this.reconnectTimeout = setTimeout(() => {
+			this.initializeWebSocket();
+		}, 3000);
+	}
+
+	// 关闭 WebSocket 连接  
+	closeSocket() {
+		if (this.socketTask) {
+			uni.closeSocket({
+				success: () => {
+					console.log('WebSocket连接已关闭');
+					this.isOpen = false;
+				},
+				fail: (error) => {
+					console.error('关闭WebSocket连接失败', error);
+				}
+			});
+			this.socketTask = null;
+		}
+	}
+
+	// 外部注册消息回调函数  
+	onMessage(callback) {
+		this.messageCallbacks.push(callback);
+	}
+
+	// 外部注销消息回调函数  
+	offMessage(callback) {
+		this.messageCallbacks = []
+	}
+
+	// 销毁 WebSocket 连接，清理资源  
+	destroy() {
+		this.closeSocket();
+		clearInterval(this.heartbeatInterval);
+		clearTimeout(this.reconnectTimeout);
+		this.messageCallbacks = [];
+	}
+}
+
+export default WebsocketUtil;