2022/3/15

MingGaoApp/App.vue

@@ -5,7 +5,6 @@
 
 			// 文本消息
 			socketTask: null,
-			// urlData: "ws://114.115.147.140:12345/api/api_gateway?method=control_center.real_time.im_message",
 			urlData: "wss://www.toreskj.com/api/api_gateway?method=control_center.real_time.im_message",
 			// urlData: "ws://192.168.1.17:12345/api/api_gateway?method=control_center.real_time.im_message",
 			is_open_socket: false, // 确保websocket是打开状态
@@ -24,7 +23,9 @@
 			reconnectTimeOutObj: null, // 重连之后多久再次重连
 			// 测试
 			app: [],
-			hdskdh: null
+			
+			// 消息发送加载
+			msgSetTime: null,
 		},
 		onLoad() {},
 		onLaunch: function() {
@@ -32,32 +33,46 @@
 			// App启动
 
 			var that = this
+			// uni.getStorage({
+			// 	key: 'session_key',
+			// 	success: function(res) {
+			// 		that.globalData.token = res.data
+			// 		// console.log('登录成功了')
+			// 		that.msgInit(); // 文本初始化
+			// 	},
+			// 	fail: function(err) {
+			// 		console.log(err)
+			// 		console.log('没有登录成功')
+			// 	}
+			// })
+		},
+		onShow: function() {
+			var that = this
+			// App展示在前台
+			console.log('+++++++++++++++++++App Show-------------------------------------')
+			// this.msgInit(); // 再进行请求
 			uni.getStorage({
 				key: 'session_key',
 				success: function(res) {
-					// console.log(res)
 					that.globalData.token = res.data
 					// console.log('登录成功了')
+					console.log(res)
 					that.msgInit(); // 文本初始化
 				},
 				fail: function(err) {
-					// console.log(err)
-					// console.log('没有登录成功')
+					console.log(err)
+					console.log('没有登录成功')
 				}
 			})
 		},
-		onShow: function() {
-			// App展示在前台
-			console.log('+++++++++++++++++++App Show-------------------------------------')
-			this.msgInit(); // 再进行请求
-		},
 		onHide: function() {
 			// App不再再展示在前台
-			// this.close(); // 关闭
+			this.close(); // 关闭
 		},
 		methods: {
 			// 实时通信 - 初始化
 			msgInit() {
+				console.log('进入了实时通信初始化=--------------------------', this.globalData.token)
 				var that = this
 				// 连接webscoket
 				that.globalData.socketTask = uni.connectSocket({
@@ -83,6 +98,7 @@
 						async success(res) {
 							that.globalData.is_open_socket = true
 							console.log("消息发送成功");
+							uni.hideLoading(); // 关闭通信异常弹框
 							
 						},
 					});
@@ -96,6 +112,7 @@
 					var val = JSON.parse(res.data)
 					console.log('这是返回的内容---------', val)
 					if (val.action == 'list') {
+						clearTimeout(that.globalData.msgSetTime); // 消息发送成功，清除发送失败定时器
 						console.log('这是发送人的ID', that.globalData.userId)
 						var obj1 = {
 							'action': 'list', // 动作标识，必填
@@ -112,7 +129,7 @@
 						});
 						that.globalData.userId = null
 					} else if (val.action == 'none') {
-						console.log('进入了none')
+						console.log('进入了none', val)
 						that.globalData.list = val.data
 						this.$store.state.list = val.data
 					} else if (val.action == 'recv_video') {
@@ -144,6 +161,9 @@
 				// 连接失败
 				that.globalData.socketTask.onError((res) => {
 					// console.log(res, '连接错误');
+					uni.showLoading({
+						title: "通信异常，连接中..."
+					})
 					clearTimeout(this.globalData.timeoutObj);
 					setTimeout(() => {
 						that.reconnect();
@@ -159,6 +179,7 @@
 					//onmessage拿到返回的心跳就说明连接正常
 					var obj = {
 						'action': 'keepalive', // 动作标识，必填
+						'type': 'App',
 						'recv_user_id': '', // 接收人用户id， 非必填
 						'data': {
 							 msg_status: false,
@@ -172,7 +193,11 @@
 							// console.log('消息发送成功1111')
 						}
 					});
-					console.log('进入心跳机制了')
+					console.log('进入心跳机制了', that.globalData.socketTask)
+					let ws_temp = null
+					ws_temp = that.globalData.socketTask
+					that.globalData.socketTask = ws_temp
+					ws_temp = null
 				}, this.globalData.timeout)
 			},
 			// 清除心跳机制
@@ -212,6 +237,7 @@
 				var that = this
 				// console.log('已经手动关闭了')
 				that.globalData.socketTask.close()
+				that.globalData.socketTask = null
 				clearTimeout(that.globalData.timeoutObj);
 				clearTimeout(that.globalData.reconnectTimeOutObj);
 			},

MingGaoApp/pages/response/details.vue

@@ -43,7 +43,8 @@
 <script>
 	import store from '@/store/index.js'; //需要引入store
 	let App = getApp();
-	var API = App.globalData.socketTask;
+	// var API = App.globalData.socketTask;
+	var API = App.globalData;
 	export default {
 		data() {
 			return {
@@ -70,14 +71,14 @@
 			msg_list(val) {
 				// 实现打开聊天框后滚动条定位到最下方
 				// this.$nextTick(() => {
-				// 	// var div = document.getElementById("msgBox");
-				// 	// div.scrollTop = div.scrollHeight;
-				// 	// console.log(div.scrollHeight)
+				// 	var div = document.getElementById("msgBox");
+				// 	div.scrollTop = div.scrollHeight;
+				// 	console.log(div.scrollHeight)
 
-				// 	// const query = uni.createSelectorQuery().in(this);
-				// 	// query.select('.details_ul').boundingClientRect(data => {
-				// 	// 	console.log(data)
-				// 	// }).exec();
+				// 	const query = uni.createSelectorQuery().in(this);
+				// 	query.select('.details_ul').boundingClientRect(data => {
+				// 		console.log(data)
+				// 	}).exec();
 				// });
 
 			},
@@ -109,7 +110,7 @@
 			videoData() {
 				return this.$store.state.video
 			},
-
+		
 		},
 		computed: {
 			listData() {
@@ -155,6 +156,7 @@
 			// 按回车键发送数据
 			search() {
 				var that = this
+				console.log(that.val)
 				if (that.value !== "") {
 					var obj = {
 						'action': 'send', // 动作标识，必填
@@ -164,11 +166,13 @@
 							'msg_info': that.value, // 发送消息
 						}
 					}
-					// App.globalData.userId = this.value.user_id
-					App.globalData.userId = null
+					console.log(that.value.user_id)
+					// App.globalData.userId = null
+					App.globalData.userId = that.val.user_id
+					console.log(obj, '发送的数据', that.val.user_id, App.globalData.socketTask)
 					that.transmit(obj)
 				} else {
-					this.$refs.uToast.show({
+					that.$refs.uToast.show({
 						message: '不能为空！',
 						type: 'error',
 						icon: true,
@@ -179,7 +183,15 @@
 			// websocket发送
 			transmit(obj) {
 				var that = this
-				API.send({
+				// App.globalData.userId = that.value.user_id
+				App.globalData.msgSetTime = setTimeout(() => {
+					that.$refs.uToast.show({
+						message: '消息发送失败，请关闭程序重试！',
+						type: 'error',
+						icon: true,
+					})
+				}, 10000)
+				API.socketTask.send({
 					data: JSON.stringify(obj),
 					async success(res) {
 						that.msg_list = [...that.msg_list, {
@@ -188,6 +200,12 @@
 						}]
 						that.value = ''
 					},
+					fali(err) {
+						console.log('消息发送失败了', err)
+					},
+					complete(com) {
+						console.log('消息发送完成，但不知道成没成功', com)
+					}
 				});
 			},
 

MingGaoApp/pages/response/index.vue

@@ -71,7 +71,8 @@
 <script>
 	import store from '@/store/index.js'; //需要引入store
 	let App = getApp();
-	var API = App.globalData.socketTask;
+	// var API = App.globalData.socketTask;
+	var API = App.globalData;
 	export default {
 		components: {},
 		// 过滤
@@ -170,10 +171,6 @@
 			}
 		},
 		methods: {
-			loadmoreAxios() {
-				console.log(this.list)
-			},
-
 			// 进入详情
 			defail(data) {
 				var that = this
@@ -183,7 +180,7 @@
 					'recv_user_id': data.user_id, // 接收人用户id， 非必填
 					'data': {}
 				}
-				API.send({
+				API.socketTask.send({
 					data: JSON.stringify(obj),
 					async success(res) {
 						console.log("消息发送成功");
@@ -212,15 +209,17 @@
 
 			// 获取应答列表
 			async msgDataList() {
+				var that = this
 				console.log('进入获取应答列表了')
 				var obj = {
 					'action': 'list', // 动作标识，必填
 					// 'send_user_id': '', // 接收人用户id， 非必填
 					'data': {}
 				}
-				API.send({
+				API.socketTask.send({
 					data: JSON.stringify(obj),
 					async success(res) {
+						that.loading = false
 						console.log("消息发送成功");
 					},
 				});
@@ -228,17 +227,16 @@
 		},
 
 		onReady() {
-			// this.loading = true
 		},
 
 		async onLoad() {
 			var that = this
-
+			that.loading = true
 			// var that = this
 			// that.list = []
 			// // console.log('==============', this.$store.state.list)
 			// that.list = this.$store.state.list
-
+			
 
 			// uni.startPullDownRefresh(); // 开始刷新
 			uni.getSystemInfo({ //异步获取。
@@ -271,9 +269,10 @@
 					// 'send_user_id': '', // 接收人用户id， 非必填
 					'data': {}
 				}
-				API.send({
+				API.socketTask.send({
 					data: JSON.stringify(obj),
 					async success(res) {
+						that.loading = false
 						console.log("消息发送成功");
 					},
 				});

MingGaoApp/pages/response/video.nvue

@@ -52,7 +52,8 @@
 <script>
 	import store from '@/store/index.js'; //需要引入store
 	let App = getApp();
-	var API = App.globalData.socketTask;
+	// var API = App.globalData.socketTask;
+	var API = App.globalData;
 	
 	import permision from "@/zego-express-video-uniapp/permission.js";
 	import ZegoExpressEngine from '@/zego-express-video-uniapp/lib/ZegoExpressEngine';
@@ -341,13 +342,14 @@
 					// 	'send_user_id': that.videoObj.user_id, // 接收人用户id， 非必填
 					// 	'data': {}
 					// }
-					console.log('-----------接收人用户id-------------', that.videoObj.user_id)
+					console.log('-----------接收人用户id-------------', that.videoObj.user_id, API)
 					obj = {
 						'action': 'list', // 动作标识，必填
+						'type': '当前为挂断',
 						'recv_user_id': that.videoObj.user_id, // 接收人用户id， 非必填
 						'data': {}
 					}
-					API.send({
+					API.socketTask.send({
 						data: JSON.stringify(obj),
 						async success(res) {
 							console.log("消息发送成功");
@@ -426,7 +428,7 @@
 		}
 
 		.video_you {
-			background: #ff0;
+			background: #000;
 			width: 620px;
 			height: 600px;
 			position: absolute;

MingGaoApp/util/url.js

@@ -1,8 +1,8 @@
 export default{
 	// baseUrl:"http://114.115.147.140:12345"
 	// baseUrl:"https://yfznscd.com"
-	// baseUrl:"https://www.toreskj.com"
+	baseUrl:"https://www.toreskj.com"
 	// baseUrl:"http://192.168.1.17:12345"
 	// baseUrl:"http://192.168.1.77:12345"
-	baseUrl:"https://www.toreskj.com"
+	// baseUrl:"https://www.toreskj.com"
 }