下单页面调整,确认订单页面调整
This commit is contained in:
@@ -13,7 +13,8 @@ const useWebSocket = (options = {}) => {
|
||||
initMessage,
|
||||
initMessageRetryCount = 3, // 新增:初始化消息发送重试次数
|
||||
initMessageRetryInterval = 2000, // 新增:初始化消息重试间隔
|
||||
maxReconnectDuration = Infinity
|
||||
maxReconnectDuration = Infinity,
|
||||
onMessage
|
||||
} = options;
|
||||
|
||||
const autoReconnect = ref(true); //是否自动重新连接
|
||||
@@ -56,7 +57,7 @@ const useWebSocket = (options = {}) => {
|
||||
};
|
||||
|
||||
// 连接 WebSocket
|
||||
const connect = () => {
|
||||
const connect = (connectMsg) => {
|
||||
if (!isNetworkConnected.value) {
|
||||
uni.showToast({
|
||||
title: '网络未连接...',
|
||||
@@ -71,7 +72,6 @@ const useWebSocket = (options = {}) => {
|
||||
|
||||
// 关闭现有连接并清理资源
|
||||
closeExistingConnection();
|
||||
|
||||
socketTask.value = uni.connectSocket({
|
||||
url: uni.conf.baseUrlwws,
|
||||
success: (res) => {
|
||||
@@ -90,10 +90,13 @@ const useWebSocket = (options = {}) => {
|
||||
if (socketTask.value) {
|
||||
socketTask.value.onOpen(() => {
|
||||
// 初始化 初始购物车
|
||||
sendMessage(initMessage)
|
||||
sendMessage(connectMsg?connectMsg:initMessage)
|
||||
});
|
||||
socketTask.value.onMessage((res) => {
|
||||
receivedMessages.value = JSON.parse(res.data)
|
||||
if(onMessage){
|
||||
onMessage(receivedMessages.value)
|
||||
}
|
||||
// receivedMessages.value.push(list);
|
||||
if (receivedMessages.value == 'ok' || receivedMessages.value.operate_type == 'init') {
|
||||
console.log('初始化正常,心跳响应正常');
|
||||
@@ -341,7 +344,7 @@ const useWebSocket = (options = {}) => {
|
||||
sendMessage,
|
||||
closeSocket,
|
||||
receivedMessages,
|
||||
closeExistingConnection,
|
||||
closeExistingConnection,connect,
|
||||
onShowconnect,
|
||||
initNetworkListener
|
||||
};
|
||||
|
||||
Reference in New Issue
Block a user