From 21fb37c7162d5b47a14d6438870377c85fcc0b52 Mon Sep 17 00:00:00 2001 From: qingyiay <2386314947@qq.com> Date: 星期六, 07 十月 2023 10:23:21 +0800 Subject: [PATCH] 修改装卸员页面 调整websocket逻辑 --- store/index.js | 71 +++++++++++++++++++++++++---------- 1 files changed, 50 insertions(+), 21 deletions(-) diff --git a/store/index.js b/store/index.js index 37a132f..bdb23b7 100644 --- a/store/index.js +++ b/store/index.js @@ -143,6 +143,11 @@ 'https://mx.jzeg.cn:9096/appimg/image/tour/driver/sj43.jpg', 'https://mx.jzeg.cn:9096/appimg/image/tour/driver/sj44.jpg', ], + wsgVisiable: false, //纾呮埧蹇欑寮圭獥鎺у埗 + wsgContent: '', + globalIsFirstWeighing: 1, //鏄惁鏄涓�娆′笂纾� + confirmWeighVisiable: false, //纾呮埧绠$悊纭绉伴噸瀹屾垚鎻愮ず寮圭獥 + confirmWeighContent: '' }, mutations: { lengthchange(state, payload) { @@ -186,6 +191,9 @@ changeuserInfo(state, payload) { state.globaluserInfo = payload }, + changesocketTask(state, payload) { + state.socketTask = payload + }, // 鏀圭増鍏ㄥ眬websocket鐘舵�� changeisconnect(state, payload) { state.globalisconnect = payload @@ -206,10 +214,14 @@ }, // 鏀瑰彉閲嶈繛娆℃暟 changereconnectNum(state, payload) { - if (state.connectNum < 6) { - state.connectNum += payload + if (payload.isWeigh) { + state.connectNum = payload.connectNum } else { - state.connectNum = payload + if (state.connectNum < 6) { + state.connectNum += payload.connectNum + } else { + state.connectNum = payload.connectNum + } } }, changeablePrintInduction(state, payload) { @@ -217,12 +229,27 @@ }, changeablePrintOut(state, payload) { state.ablePrintOut = payload + }, + changewsgVisiable(state, payload) { + state.wsgVisiable = payload + }, + changewsgContent(state, payload) { + state.wsgContent = payload + }, + changeglobalIsFirstWeighing(state, payload) { + state.globalIsFirstWeighing = payload + }, + changeconfirmWeighVisiable(state, payload) { + state.confirmWeighVisiable = payload + }, + changeconfirmWeighContent(state, payload) { + state.confirmWeighContent = payload } }, actions: { websocketInit({ state, dispatch, commit }) { let wsUrl = `${webSocketUrl}?access_token=${uni.getStorageSync('token')}` - state.socketTast = uni.connectSocket({ + state.socketTask = uni.connectSocket({ url: wsUrl, header: { CLIENT_TOC: 'Y' }, success: res => { @@ -237,19 +264,20 @@ console.log('ws澶辫触'); commit('changereconnectState', false) dispatch('reconnect') + commit('changeisconnect', false) } }) - state.socketTast.onOpen(() => dispatch('websocketOnOpen')) - state.socketTast.onMessage(result => dispatch('websocketOnMessage', result.data)) - state.socketTast.onClose(e => dispatch('websocketOnClose', e)) - state.socketTast.onError(e => dispatch('websocketOnError', e)) + state.socketTask.onOpen(() => dispatch('websocketOnOpen')) + state.socketTask.onMessage(result => dispatch('websocketOnMessage', result.data)) + state.socketTask.onClose(e => dispatch('websocketOnClose', e)) + state.socketTask.onError(e => dispatch('websocketOnError', e)) }, websocketOnOpen({ state, commit }) { console.log('ws鎵撳紑') clearInterval(state.reconnectTimeOut) clearInterval(state.globalIntervalId) state.globalIntervalId = setInterval(() => { - state.socketTast.send({ + state.socketTask.send({ data: JSON.stringify({ type: 'ping' }), success(e) { console.log(e, '鍙戦�佸績璺虫垚鍔�') @@ -258,24 +286,25 @@ }, 30000) }, websocketOnClose({ state, commit, dispatch }, e) { - if (!state.socketTast) return + if (!state.socketTask) return console.log('ws鍏抽棴', e) - state.socketTast.close(e => { + state.socketTask.close(e => { commit('changeisconnect', false) }) clearInterval(state.globalIntervalId) clearInterval(state.reconnectTimeOut) - state.socketTast = null + state.socketTask = null commit('changereconnectState', false) - if (state.connectNum < 6 && state.globalisLogin) { + console.log(state.connectNum, state.connectNum.connectNum, '閾炬帴鏁�'); + if (state.connectNum < 6 || state.connectNum.connectNum < 6 && state.globalisLogin) { uni.showToast({ - title: `杩炴帴澶辫触锛屾鍦ㄥ皾璇曠${state.connectNum}娆¤繛鎺, + title: '杩炴帴澶辫触锛屾鍦ㄥ皾璇曢噸鏂拌繛鎺�', icon: 'none' }) - commit('changereconnectNum', 1) + commit('changereconnectNum', { connectNum: 1, isWeigh: false }) dispatch('reconnect') } else if (state.connectNum >= 6 && state.globalisLogin) { - commit('changereconnectNum', 1) + commit('changereconnectNum', { connectNum: 1, isWeigh: false }) uni.showToast({ title: '缃戠粶寮傚父,璇风◢鍚庨噸璇�', icon: 'none' @@ -289,17 +318,17 @@ console.log('ws鎶ラ敊', e) clearInterval(state.globalIntervalId) clearInterval(state.reconnectTimeOut) - state.socketTast = null + state.socketTask = null commit('changereconnectState', false) - if (state.connectNum < 6 && state.globalisLogin) { + if (state.connectNum < 6 || state.connectNum.connectNum < 6 && state.globalisLogin) { uni.showToast({ - title: `杩炴帴澶辫触锛屾鍦ㄥ皾璇曠${state.connectNum}娆¤繛鎺, + title: '杩炴帴澶辫触锛屾鍦ㄥ皾璇曢噸鏂拌繛鎺�', icon: 'none' }) - commit('changereconnectNum', 1) + commit('changereconnectNum', { connectNum: 1, isWeigh: false }) dispatch('reconnect') } else if (state.connectNum > 6 && state.globalisLogin) { - commit('changereconnectNum', 1) + commit('changereconnectNum', { connectNum: 1, isWeigh: false }) uni.showToast({ title: '缃戠粶寮傚父,璇风◢鍚庨噸璇�', icon: 'none' -- Gitblit v1.9.1