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