From 6efa94990672ea4c1d83b6f0e7cb5b66d020bc2d Mon Sep 17 00:00:00 2001 From: yangan <yangan0921@163.com> Date: 星期三, 12 六月 2024 10:19:59 +0800 Subject: [PATCH] feat:转发bug --- store/index.js | 98 +++++++++++++++++++++++++++++++++---------------- 1 files changed, 66 insertions(+), 32 deletions(-) diff --git a/store/index.js b/store/index.js index 37a132f..f9aa732 100644 --- a/store/index.js +++ b/store/index.js @@ -93,8 +93,8 @@ globalIntervalId: null, is_open_socket: false, //閬垮厤閲嶅杩炴帴 connectNum: 1, //閲嶈繛娆℃暟, - reconnectTimeOut: null, - // 鎵撳嵃鍑哄叆闂ㄨ瘉 涓�娆″氨鍙互鏈夋墦鍗板叆闂ㄨ瘉锛� 涓ゆ鍙互鏈夊叆闂ㄨ瘉 鍑洪棬璇� 0娆′竴寮犻兘娌℃湁 + reconnectTimeOut: null, //閲嶆柊閾炬帴鐨勫畾鏃跺櫒 + // 鎵撳嵃鍑哄叆闂ㄨ瘉 涓�娆″氨鍙互鏈夋墦鍗板叆闂ㄨ瘉锛� 涓ゆ鍙互鏈夊叆闂ㄨ瘉 鍑洪棬璇� 0娆′竴寮犻兘娌℃湁 ablePrintInduction: false, //鍏ラ棬璇� ablePrintOut: false, //鍑洪棬璇� driverTourImgList: ['https://mx.jzeg.cn:9096/appimg/image/tour/driver/sj1.png', @@ -143,11 +143,15 @@ '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: '', + // 绉伴噸绋冲畾鎬� 0/绋冲畾 1/闈炵ǔ瀹� 闈炵ǔ瀹氭�佷笉鑳界偣绉伴噸 + globalWarning: false, }, mutations: { - lengthchange(state, payload) { - state.fleetDriverDataLength = payload - }, setUserInfo(state, identity) { state.userInfo = userObj[identity] }, @@ -186,7 +190,10 @@ changeuserInfo(state, payload) { state.globaluserInfo = payload }, - // 鏀圭増鍏ㄥ眬websocket鐘舵�� + changesocketTask(state, payload) { + state.socketTask = payload + }, + // 鏀圭増鍏ㄥ眬websocket鐘舵�侊紙鍒ゆ柇鏄惁姝e父閾炬帴锛� changeisconnect(state, payload) { state.globalisconnect = payload }, @@ -206,10 +213,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,14 +228,36 @@ }, 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 + }, + // 鏀瑰彉绋冲畾鎬� + changeWarning(state, payload) { + state.globalWarning = 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' }, + header: { + clientToc: 'Y' , + 'CLIENT_TOC': 'Y', + }, success: res => { console.log(res, 'socketSuccess') if (res.errMsg === 'connectSocket:ok') { @@ -237,19 +270,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) + 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 +292,24 @@ }, 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) { + 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 +323,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' @@ -325,4 +359,4 @@ } }) -export default store \ No newline at end of file +export default store -- Gitblit v1.9.1