mirror of
https://gitee.com/beijing_hongye_huicheng/lilishop-uniapp.git
synced 2025-12-18 00:15:54 +08:00
Merge branch 'master' of https://gitee.com/beijing_hongye_huicheng/lilishop-uniapp
This commit is contained in:
lemon橪
@@ -19,7 +19,10 @@
|
||||
<view>
|
||||
<view class="user-name">{{ user.nickName }}</view>
|
||||
<view class="margin-left padding-chat bg-user-orang" style="border-radius: 35rpx; ">
|
||||
<text style="word-break: break-all;" v-if="item.messageType === 'MESSAGE'">{{ item.text }}</text>
|
||||
<text style="word-break: break-all;"
|
||||
v-if="item.messageType === 'MESSAGE' && !emojistwo.includes(item.text)">{{ item.text }}</text>
|
||||
<view v-if="item.messageType === 'MESSAGE' && emojistwo.includes(item.text)"
|
||||
v-html="textReplaceEmoji(item.text)"></view>
|
||||
<view v-if="item.messageType == 'GOODS'">
|
||||
<view class="goodsCard u-flex u-row-between u-p-b-0" style="width:100%;margin: 0 0; ">
|
||||
<view class="imagebox" @click="jumpGoodDelic(item)">
|
||||
@@ -73,7 +76,10 @@
|
||||
<view>
|
||||
<view class="other-name">{{ toUser.name }}</view>
|
||||
<view class="margin-left padding-chat flex-column-start bg-to-color" style="border-radius: 35rpx;">
|
||||
<text style="word-break: break-all;" v-if="item.messageType === 'MESSAGE'">{{ item.text }}</text>
|
||||
<text style="word-break: break-all;"
|
||||
v-if="item.messageType === 'MESSAGE' && !emojistwo.includes(item.text)">{{ item.text }}</text>
|
||||
<view v-if="item.messageType === 'MESSAGE' && emojistwo.includes(item.text)"
|
||||
v-html="textReplaceEmoji(item.text)"></view>
|
||||
<view v-if="item.messageType === 'GOODS'">
|
||||
<view class="goodsCard u-flex u-row-between u-p-b-0" style="width:100%;margin: 0 0; ">
|
||||
<view class="imagebox" @click="jumpGoodDelic(item)">
|
||||
@@ -204,6 +210,7 @@ import {
|
||||
beautifyTime
|
||||
} from "@/utils/filters.js"
|
||||
import config from '@/config/config.js'
|
||||
import { textReplaceEmoji, emojistwo } from '@/utils/emojis.js';
|
||||
export default {
|
||||
// 页面卸载后清除imGoodId
|
||||
onUnload () {
|
||||
@@ -216,7 +223,8 @@ export default {
|
||||
}
|
||||
},
|
||||
onLoad (options) {
|
||||
this.sokcet();
|
||||
console.log(5555555555555555);
|
||||
console.log(emojistwo);
|
||||
// 没有goodsid则不显示 发送商品弹窗
|
||||
this.showHideModel = options.goodsid
|
||||
// 发送后刷新页面不显示 发送商品弹窗 local里面imGoodId不为空显示
|
||||
@@ -278,6 +286,8 @@ export default {
|
||||
|
||||
data () {
|
||||
return {
|
||||
textReplaceEmoji,
|
||||
emojistwo,
|
||||
socketOpen: false, //是否连接
|
||||
storage,
|
||||
fixed: 'fixed',
|
||||
@@ -400,17 +410,21 @@ export default {
|
||||
uni.onSocketOpen(function (res) {
|
||||
_this.socketOpen = true;
|
||||
});
|
||||
// 监听连接失败
|
||||
uni.onSocketError(function (err) {
|
||||
if (err && err.code !== 1000) {
|
||||
setTimeout(function () {
|
||||
_this.socketOpen = true;
|
||||
uni.connectSocket({
|
||||
url: url,
|
||||
});
|
||||
}, 5 * 1000)
|
||||
}
|
||||
});
|
||||
if (!this.socketOpen) {
|
||||
// 监听连接失败
|
||||
uni.onSocketError(function (err) {
|
||||
let count = 0;
|
||||
if (count < 3) {
|
||||
if (err && err.code !== 1000) {
|
||||
_this.socketOpen = true;
|
||||
uni.connectSocket({
|
||||
url: url,
|
||||
});
|
||||
count = count + 1
|
||||
}
|
||||
}
|
||||
});
|
||||
}
|
||||
// 监听连接关闭
|
||||
uni.onSocketClose(function (err) {
|
||||
if (err && err.code !== 1000) {
|
||||
@@ -424,8 +438,15 @@ export default {
|
||||
});
|
||||
// 监听收到信息
|
||||
uni.onSocketMessage(function (res) {
|
||||
console.log(res.data, 'resresresresresres');
|
||||
uni.hideLoading()
|
||||
console.log(res.data);
|
||||
res.data = JSON.parse(res.data)
|
||||
console.log(res.data.result);
|
||||
if (res.data.messageResultType == 'MESSAGE') {
|
||||
_this.msgList.push(res.data.result)
|
||||
console.log(_this.msgList)
|
||||
}
|
||||
console.log(res.data)
|
||||
_this.msgGo()
|
||||
})
|
||||
} catch (e) {
|
||||
|
||||
|
||||
166
pages/mine/im/socket.js
Normal file
166
pages/mine/im/socket.js
Normal file
@@ -0,0 +1,166 @@
|
||||
import config from '@/config/config.js'
|
||||
import storage from '@/utils/storage';
|
||||
class socketIO {
|
||||
constructor(data, time, url) {
|
||||
this.socketTask = null
|
||||
this.is_open_socket = false //避免重复连接
|
||||
this.url = config.baseWsUrl + '/' + storage.getAccessToken() //连接地址
|
||||
this.data = data ? data : null
|
||||
this.connectNum = 1 // 重连次数
|
||||
this.traderDetailIndex = 100 // traderDetailIndex ==2 重连
|
||||
this.accountStateIndex = 100 // traderDetailIndex ==1 重连
|
||||
this.followFlake = false // traderDetailIndex == true 重连
|
||||
//心跳检测
|
||||
this.timeout = time ? time : 15000 //多少秒执行检测
|
||||
this.heartbeatInterval = null //检测服务器端是否还活着
|
||||
this.reconnectTimeOut = null //重连之后多久再次重连
|
||||
}
|
||||
// 进入这个页面的时候创建websocket连接【整个页面随时使用】
|
||||
connectSocketInit (data) {
|
||||
this.data = data
|
||||
this.socketTask = uni.connectSocket({
|
||||
url: this.url,
|
||||
success: () => {
|
||||
console.log("正准备建立websocket中...");
|
||||
// 返回实例
|
||||
return this.socketTask
|
||||
},
|
||||
});
|
||||
this.socketTask.onOpen((res) => {
|
||||
this.connectNum = 1
|
||||
console.log("WebSocket连接正常！");
|
||||
this.send(data)
|
||||
clearInterval(this.reconnectTimeOut)
|
||||
clearInterval(this.heartbeatInterval)
|
||||
this.is_open_socket = true;
|
||||
this.start();
|
||||
// 注：只有连接正常打开中 ，才能正常收到消息
|
||||
this.socketTask.onMessage((e) => {
|
||||
// 字符串转json
|
||||
let res = JSON.parse(e.data);
|
||||
console.log("res---------->", res) // 这里 查看 推送过来的消息
|
||||
if (res.data) {
|
||||
uni.$emit('getPositonsOrder', res);
|
||||
}
|
||||
});
|
||||
})
|
||||
// 监听连接失败，这里代码我注释掉的原因是因为如果服务器关闭后，和下面的onclose方法一起发起重连操作，这样会导致重复连接
|
||||
uni.onSocketError((res) => {
|
||||
console.log('WebSocket连接打开失败，请检查！');
|
||||
this.socketTask = null
|
||||
this.is_open_socket = false;
|
||||
clearInterval(this.heartbeatInterval)
|
||||
clearInterval(this.reconnectTimeOut)
|
||||
uni.$off('getPositonsOrder')
|
||||
if (this.connectNum < 6) {
|
||||
uni.showToast({
|
||||
title: `WebSocket连接失败，正尝试第${this.connectNum}次连接`,
|
||||
icon: "none"
|
||||
})
|
||||
this.reconnect();
|
||||
this.connectNum += 1
|
||||
} else {
|
||||
uni.$emit('connectError');
|
||||
this.connectNum = 1
|
||||
}
|
||||
});
|
||||
// 这里仅是事件监听【如果socket关闭了会执行】
|
||||
this.socketTask.onClose(() => {
|
||||
console.log("已经被关闭了-------")
|
||||
clearInterval(this.heartbeatInterval)
|
||||
clearInterval(this.reconnectTimeOut)
|
||||
this.is_open_socket = false;
|
||||
this.socketTask = null
|
||||
uni.$off('getPositonsOrder')
|
||||
if (this.connectNum < 6) {
|
||||
this.reconnect();
|
||||
} else {
|
||||
uni.$emit('connectError');
|
||||
this.connectNum = 1
|
||||
}
|
||||
})
|
||||
}
|
||||
// 主动关闭socket连接
|
||||
Close () {
|
||||
if (!this.is_open_socket) {
|
||||
return
|
||||
}
|
||||
this.socketTask.close({
|
||||
success () {
|
||||
uni.showToast({
|
||||
title: 'SocketTask 关闭成功',
|
||||
icon: "none"
|
||||
});
|
||||
}
|
||||
});
|
||||
}
|
||||
//发送消息
|
||||
send (data) {
|
||||
console.log("data---------->", data);
|
||||
// 注：只有连接正常打开中 ，才能正常成功发送消息
|
||||
if (this.socketTask) {
|
||||
this.socketTask.send({
|
||||
data: JSON.stringify(data),
|
||||
async success () {
|
||||
console.log("消息发送成功");
|
||||
},
|
||||
});
|
||||
}
|
||||
}
|
||||
//开启心跳检测
|
||||
start () {
|
||||
this.heartbeatInterval = setInterval(() => {
|
||||
this.send({
|
||||
"traderid": 10260,
|
||||
"type": "Ping"
|
||||
});
|
||||
}, this.timeout)
|
||||
}
|
||||
//重新连接
|
||||
reconnect () {
|
||||
//停止发送心跳
|
||||
clearInterval(this.heartbeatInterval)
|
||||
//如果不是人为关闭的话，进行重连
|
||||
if (!this.is_open_socket && (this.traderDetailIndex == 2 || this.accountStateIndex == 0 || this
|
||||
.followFlake)) {
|
||||
this.reconnectTimeOut = setInterval(() => {
|
||||
this.connectSocketInit(this.data);
|
||||
}, 5000)
|
||||
}
|
||||
}
|
||||
/**
|
||||
* @description 将 scoket 数据进行过滤
|
||||
* @param {array} array
|
||||
* @param {string} type 区分 弹窗 openposition 分为跟随和我的
|
||||
*/
|
||||
arrayFilter (array, type = 'normal', signalId = 0) {
|
||||
let arr1 = []
|
||||
let arr2 = []
|
||||
let obj = {
|
||||
arr1: [],
|
||||
arr2: []
|
||||
}
|
||||
arr1 = array.filter(v => v.flwsig == true)
|
||||
arr2 = array.filter(v => v.flwsig == false)
|
||||
if (type == 'normal') {
|
||||
if (signalId) {
|
||||
arr1 = array.filter(v => v.flwsig == true && v.sigtraderid == signalId)
|
||||
return arr1
|
||||
} else {
|
||||
return arr1.concat(arr2)
|
||||
}
|
||||
} else {
|
||||
if (signalId > 0) {
|
||||
arr1 = array.filter(v => v.flwsig == true && v.sigtraderid == signalId)
|
||||
obj.arr1 = arr1
|
||||
} else {
|
||||
obj.arr1 = arr1
|
||||
}
|
||||
obj.arr2 = arr2
|
||||
return obj
|
||||
}
|
||||
}
|
||||
}
|
||||
export {
|
||||
socketIO
|
||||
}
|
||||
Reference in New Issue
Block a user