xiaoning
/
yogaApp
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

upbug

Browse Source
main
zouyanyan 2 weeks ago
parent 598ea2c158
commit 7f5c4fd704
9 changed files with 911 additions and 562 deletions
Show Stats Download Patch File Download Diff File

14
components/chat/submit.vue
Unescape View File

@ -152,7 +152,7 @@
// }, 0) // }, 0)
// } // }
if (this.msg.length > 1) { if (this.msg.length > 0) {
// 0为表情和文字 // 0为表情和文字
this.send(this.msg, 'txt'); this.send(this.msg, 'txt');
this.ifmore=true; this.ifmore=true;
@ -161,7 +161,7 @@
}, },
inputs(e) { inputs(e) {
var chatm = e.detail.value; var chatm = e.detail.value;
if (chatm.length > 1) { if (chatm.length > 0) {
this.ifmore=false; this.ifmore=false;
} }
else{ else{
@ -431,12 +431,12 @@
display: flex; display: flex;
align-items: flex-end; align-items: flex-end;
box-sizing: border-box; box-sizing: border-box;
padding: 14rpx 20rpx; padding: 14rpx;
image { image {
width: 56rpx; width: 60rpx;
height: 56rpx; height: 60rpx;
margin: 0 10rpx; margin: 0 8rpx;
flex: auto; flex: auto;
} }
.btnt { .btnt {
@ -464,7 +464,7 @@
.record { .record {
line-height: 44rpx; line-height: 44rpx;
text-align: center; text-align: center;
font-size: 20rpx; font-size: 24rpx;
color: rgba(39, 40, 50, 0.6); color: rgba(39, 40, 50, 0.6);
} }
} }

4
manifest.json
Unescape View File

@ -2,8 +2,8 @@
"name" : "瑜伽汇", "name" : "瑜伽汇",
"appid" : "__UNI__B6E0086", "appid" : "__UNI__B6E0086",
"description" : "瑜伽汇", "description" : "瑜伽汇",
"versionName" : "1.0.12", "versionName" : "1.0.16",
"versionCode" : 1012, "versionCode" : 1016,
"transformPx" : false, "transformPx" : false,
"app-plus" : { "app-plus" : {
"flexible" : true, "flexible" : true,

423
pages/chat/chat.vue
Unescape View File

@ -90,18 +90,26 @@
<text class="uname">{{item.fromname}}</text> <text class="uname">{{item.fromname}}</text>
</view> </view>
<view v-if="item.type == 'txt'" class="message"> <view v-if="item.type == 'txt'" class="message">
<view v-if="item.ifread" class="read">已读</view>
<view v-else class="noread">未读</view>
<view class="msg-text"> <view class="msg-text">
<text selectable>{{item.content}}</text> <text selectable>{{item.content}}</text>
</view> </view>
</view> </view>
<view v-if="item.type == 'image'" @tap="previewImg(item.content)" class="message"> <view v-if="item.type == 'image'" @tap="previewImg(item.content)" class="message">
<view v-if="item.ifread" class="read">已读</view>
<view v-else class="noread">未读</view>
<image :src="item.content" class="msg-img" mode="widthFix"></image> <image :src="item.content" class="msg-img" mode="widthFix"></image>
</view> </view>
<view v-if="item.type == 'video'" class="messagevideo"> <view v-if="item.type == 'video'" class="messagevideo">
<view v-if="item.ifread" class="read">已读</view>
<view v-else class="noread">未读</view>
<!-- 视频 --> <!-- 视频 -->
<myVideo :videoUrl="item.content"></myVideo> <myVideo :videoUrl="item.content"></myVideo>
</view> </view>
<view v-if="item.type == 'audio'" @click="playVoice(item.content,item.ifaudio,index)" class="message"> <view v-if="item.type == 'audio'" @click="playVoice(item.content,item.ifaudio,index)" class="message">
<view v-if="item.ifread" class="read">已读</view>
<view v-else class="noread">未读</view>
<!-- 音频 --> <!-- 音频 -->
<view class="msg-text voice" :style="{width: item.time>2? item.time*40+'rpx' :'auto'}"> <view class="msg-text voice" :style="{width: item.time>2? item.time*40+'rpx' :'auto'}">
{{item.time}}″ {{item.time}}″
@ -112,6 +120,8 @@
</view> </view>
</view> </view>
<view v-if="item.type == 'product'" class="message" > <view v-if="item.type == 'product'" class="message" >
<view v-if="item.ifread" class="read">已读</view>
<view v-else class="noread">未读</view>
<view v-if="item.send" class="msg-product" @click="gotoDetail(item)"> <view v-if="item.send" class="msg-product" @click="gotoDetail(item)">
<view v-if="item.send.type==3" class="zx"> <view v-if="item.send.type==3" class="zx">
<view class="zxname">订单咨询</view> <view class="zxname">订单咨询</view>
@ -276,15 +286,13 @@
this.sendinfo=null; this.sendinfo=null;
this.$forceUpdate(); this.$forceUpdate();
} }
// 先获取聊天记录缓存
this.getchatstore();
} }
}, },
onShow() { onShow() {
// 先获取聊天记录缓存
this.getchatstore();
// 跳转到最后一条数据 与前面的:id进行对照 // 跳转到最后一条数据 与前面的:id进行对照
setTimeout(() => { setTimeout(() => {
console.log("onShow")
this.screendo(this.unshiftmsg.length - 1); this.screendo(this.unshiftmsg.length - 1);
}, 100); }, 100);
@ -292,26 +300,24 @@
if(this.heartbeatInterval){ if(this.heartbeatInterval){
clearInterval(this.heartbeatInterval); // 停止心跳包发送 clearInterval(this.heartbeatInterval); // 停止心跳包发送
} }
// socket接收实时消息
this.socketinit();
}, },
onBackPress(options) { onBackPress(options) {
if (options.from === 'backbutton') { if (options.from === 'backbutton') {
// 来自顶部菜单的返回按钮 // 来自顶部菜单的返回按钮
// 在这里处理你的逻辑 // 在这里处理你的逻辑
console.log('返回按钮被点击'); console.log('返回按钮被点击');
this.closeWebSocket(); // this.closeWebSocket();
uni.onSocketClose(function (res) { // uni.onSocketClose(function (res) {
console.log('WebSocket 已关闭！'); // console.log('WebSocket 已关闭！');
}); // });
return false; return false;
} }
}, },
beforeDestroy() { beforeDestroy() {
console.log('界面关闭socket，beforeDestroy'); console.log('界面关闭socket，beforeDestroy');
// 在组件销毁前，确保关闭 WebSocket 连接 // 在组件销毁前，确保关闭 WebSocket 连接
this.closeWebSocket(); // this.closeWebSocket();
clearInterval(this.heartbeatInterval); // 停止心跳包发送 // clearInterval(this.heartbeatInterval); // 停止心跳包发送
}, },
methods: { methods: {
gotoDetail(item){ gotoDetail(item){
@ -385,11 +391,12 @@
}, },
// 获取聊天记录 // 获取聊天记录
getchatstore(){ getchatstore(){
console.log("getchatstore");
var that=this; var that=this;
try{ try{
this.unshiftmsg=[];
// 先获取会话缓存 // 先获取会话缓存
var data= myCache(this.info.chatId)?myCache(this.info.chatId):[]; var data= myCache(this.info.chatId)?myCache(this.info.chatId):[];
console.log("data",data)
data.forEach((cell,i)=>{ data.forEach((cell,i)=>{
cell["ifaudio"]=false; cell["ifaudio"]=false;
//时间间隔处理 //时间间隔处理
@ -410,7 +417,6 @@
} }
this.unshiftmsg.push(cell); this.unshiftmsg.push(cell);
}); });
if(this.unshiftmsg.length<=0) if(this.unshiftmsg.length<=0)
{ {
if(this.info.from=="yh"){ if(this.info.from=="yh"){
@ -453,30 +459,41 @@
]; ];
this.$forceUpdate(); this.$forceUpdate();
} }
// 如果是第一次接收消息没有缓存，且有minId则拉取离线消息
if(this.info.minId){
this.readUp(1);
}
} }
else{ else{
// 跳转到最后一条数据 与前面的:id进行对照 // 跳转到最后一条数据 与前面的:id进行对照
setTimeout(() => { setTimeout(() => {
that.screendo(that.unshiftmsg.length-1); that.screendo(that.unshiftmsg.length-1);
}, 100); }, 100);
// 已经有缓存，则拉取离线消息
this.info.minId=this.unshiftmsg[this.unshiftmsg.length-1].id;
this.$forceUpdate();
// 请求服务器加载加载拉取离线聊天记录
if(this.info.minId&&this.info.minId>0){
this.readUp(1);
}
} }
} }
catch(err){ catch(err){
console.log(err); console.log(err);
} }
// socket接收实时消息
this.socketinit();
},
// 是否是列表中已经存在了minId
ifpull(){
var ret=true;
this.unshiftmsg.forEach((cell)=>{
if(cell.id&&this.info.minId&&parseInt(cell.id)>=parseInt(this.info.minId)){
ret=false;
}
});
return ret;
},
// 消息是否存在列表中
ifadd(id){
var ret=true;
this.unshiftmsg.forEach((cell)=>{
if(cell.id==id){
ret=false;
}
});
return ret;
}, },
// 定时心跳包 // 定时心跳包
startHeartbeat() { startHeartbeat() {
@ -497,54 +514,59 @@
// ws接收消息 // ws接收消息
socketinit(){ socketinit(){
var that = this; var that = this;
if (!this.isConnected) { this.socketTask=uni.connectSocket({
this.socketTask=uni.connectSocket({ url: "wss://www.sanduolantoyoga.com/yoga-imserver/",
url: "wss://www.sanduolantoyoga.com/yoga-imserver/", header: {
header: { // 'content-type': 'application/json',
// 'content-type': 'application/json', Authorization: uni.getStorageSync("token"),
Authorization: uni.getStorageSync("token"), },
}, success: (res) => {
success: (res) => { console.log(res, 'socket连接成功success');
console.log(res, 'socket连接成功success'); // 获取当前聊天中的minId 拉取离线信息
}, that.getReadedId();
fail: (res) => { },
console.log(res, 'socket连接失败') fail: (res) => {
console.log(res, 'socket连接失败')
},
complete: (res) => {
console.log(res,'socket连接成功complete');
}
});
uni.onSocketOpen(res => {
console.log('WebSocket连接已打开！');
that.isConnected = true;
// 发送登录心跳包
uni.sendSocketMessage({
data: JSON.stringify({
"cmd": 0,//心跳
"data": {
"accessToken":uni.getStorageSync("token"),
},
}), // 发送心跳包数据 // 发送的消息内容
success(re) {
console.log(re);
console.log('消息发送成功！')
}, },
complete: (res) => { fail(err) {
console.log(res,'socket连接成功complete'); console.log(err);
console.log('消息发送失败！')
} }
}); });
uni.onSocketOpen(res => {
console.log('WebSocket连接已打开！'); // 发送心跳包
that.isConnected = true; this.startHeartbeat();
// 发送登录心跳包
uni.sendSocketMessage({ });
data: JSON.stringify({ uni.onSocketMessage(res => {
"cmd": 0,//心跳 console.log('收到WebSocket服务器消息：');
"data": { if(res.data){
"accessToken":uni.getStorageSync("token"), let data=JSON.parse(res.data);
}, console.log(data);
}), // 发送心跳包数据 // 发送的消息内容 if(data.data){
success(re) { data=data.data;
console.log(re); if(data){
console.log('消息发送成功！') if(this.ifadd(data.id)){
},
fail(err) {
console.log(err);
console.log('消息发送失败！')
}
});
// 发送心跳包
this.startHeartbeat();
});
uni.onSocketMessage(res => {
console.log('收到WebSocket服务器消息：');
if(res.data){
let data=JSON.parse(res.data);
console.log(data);
if(data.data){
data=data.data;
if(data){
// 是发送者发送来的消息 // 是发送者发送来的消息
if(data.recvId&&data.recvId.toString()==that.userid.toString()&&data.sendId.toString()==this.info.friendId.toString()){ if(data.recvId&&data.recvId.toString()==that.userid.toString()&&data.sendId.toString()==this.info.friendId.toString()){
// 加入聊天记录 // 加入聊天记录
@ -596,19 +618,24 @@
} }
} }
} }
// 10, "撤回" 11, "已读 " 12, "消息已读回执 " 30,"加载中标记"
if(data.type==12){
// 已读操作
this.updateRead(data);
}
} }
} }
}); }
uni.onSocketClose(res => { });
console.log('WebSocket连接已关闭！'); uni.onSocketClose(res => {
that.isConnected = false; console.log('WebSocket连接已关闭！');
clearInterval(that.heartbeatInterval); // 停止心跳包发送 that.isConnected = false;
}); clearInterval(that.heartbeatInterval); // 停止心跳包发送
uni.onSocketError(err => { });
console.error('WebSocket连接打开失败，请检查：', err); uni.onSocketError(err => {
clearInterval(that.heartbeatInterval); // 停止心跳包发送 console.error('WebSocket连接打开失败，请检查：', err);
}); clearInterval(that.heartbeatInterval); // 停止心跳包发送
} });
}, },
// 关闭WebSocket连接 // 关闭WebSocket连接
closeWebSocket() { closeWebSocket() {
@ -621,7 +648,7 @@
async setMsglist(data){ async setMsglist(data){
data.send=data.type==6?await this.getProduct(data.content):(data.type==5?await this.getOrder(data.content):null); data.send=data.type==6?await this.getProduct(data.content):(data.type==5?await this.getOrder(data.content):null);
data.type=data.type==0?'txt':(data.type==1?'image':data.type==3?'audio':(data.type==4?'video':(data.type==5?'order':(data.type==6?'product':'')))), data.type=data.type==0?'txt':(data.type==1?'image':data.type==3?'audio':(data.type==4?'video':(data.type==5?'order':(data.type==6?'product':'')))),
console.log("setMsglist",data) // console.log("setMsglist",data)
this.unshiftmsg.push(data); this.unshiftmsg.push(data);
this.$forceUpdate(); this.$forceUpdate();
setTimeout(() => { setTimeout(() => {
@ -629,6 +656,29 @@
}, 100); }, 100);
// 缓存聊天 // 缓存聊天
myCache(this.info.chatId,this.unshiftmsg); myCache(this.info.chatId,this.unshiftmsg);
// 保存最大拉取Id
this.savaMaxId({id:this.info.chatId,minId:this.info.minId});
},
savaMaxId(info){
// 保存最大拉取Id
var data= myCache("privateMsgMaxId")?myCache("privateMsgMaxId"):[];
console.log("data",data)
var ifhas=0;
data.forEach((cell,i)=>{
if(cell.id==info.id){
ifhas=1;
data[i].minId==info.minId;
}
});
if(ifhas){
// 如果存在信息修改
myCache("privateMsgMaxId",data);
}
else{
// 如果不存在信息添加
data.push(info);
myCache("privateMsgMaxId",data);
}
}, },
async getProduct(id){ async getProduct(id){
console.log("getProduct",id) console.log("getProduct",id)
@ -679,89 +729,97 @@
async readed() { async readed() {
const {data: res} = await uni.$http.put('/api/message/private/readed?friendId='+this.info.friendId); const {data: res} = await uni.$http.put('/api/message/private/readed?friendId='+this.info.friendId);
}, },
// 已读推送 // 获取当前聊天中最大minId
async readUp(ii) { async getReadedId() {
const {data: res} = await uni.$http.put('/api/message/private/readed?friendId='+this.info.friendId); const {data: res} = await uni.$http.get('/api/message/private/maxReadedId',{friendId:this.info.friendId});
this.getList(ii); if(res.data){
this.info.minId=res.data;
this.$forceUpdate();
// 保存最大拉取Id
this.savaMaxId({id:this.info.chatId,minId:this.info.minId});
this.getList();
}
}, },
// 加载对话 // 拉取离线消息
async getList(ii) { async getList() {
var that=this; // 判断当前 minId 是不是列表中已经存在了，是不再拉取，不是继续拉取
const {data: res} = await uni.$http.get('/api/message/private/pullOfflineMessage',{minId: this.info.minId}); // if(this.ifpull()){
this.triggered = false; var that=this;
if(res.data&&res.data.length>0){ const {data: res} = await uni.$http.get('/api/message/private/pullOfflineMessage',{minId: this.info.minId});
const gotonum=res.data.length; this.triggered = false;
var type=0; if(res.data&&res.data.length>0){
res.data.forEach((cell,i)=>{ var type=0;
type=cell.type; res.data.forEach((cell,i)=>{
cell["ifaudio"]=false; type=cell.type;
//时间间隔处理 cell["ifaudio"]=false;
if (i < this.unshiftmsg.length - 1) { //时间间隔处理
//这里表示头部时间还是显示一下 if (i < this.unshiftmsg.length - 1) {
let t = dateTime.spaceTime(this.oldTime, cell.fromtime); //这里表示头部时间还是显示一下
if (t) { let t = dateTime.spaceTime(this.oldTime, cell.fromtime);
this.oldTime = t; if (t) {
this.oldTime = t;
}
cell.fromtime = t;
} }
cell.fromtime = t; // 获取图片，为下面的预览做准备
} if (cell.type == 1) {
// 获取图片，为下面的预览做准备 this.imgMsg.unshift(cell.content)
if (cell.type == 1) { }
this.imgMsg.unshift(cell.content) else if(cell.type==0){
} cell.content=decodeURIComponent(cell.content);
else if(cell.type==0){ }
cell.content=decodeURIComponent(cell.content); // // 消息类型 0:文字 1:图片 2:文件 3:语音 4:视频 5 订单 6 商品 10, "撤回" 11, "已读 "12, "消息已读回执 " 30,"加载中标记"
} let mdata = {
// // 消息类型 0:文字 1:图片 2:文件 3:语音 4:视频 5 订单 6 商品 10, "撤回" 11, "已读 "12, "消息已读回执 " 30,"加载中标记" "fromname": this.userName,
let mdata = { "fromuser": this.userid,
"fromname": this.userName, "headimg": cell.headImage?cell.headImage:'/static/image/kfr.png',
"fromuser": this.userid, "toname": this.info.chatName, // 接收人
"headimg": cell.headImage?cell.headImage:'/static/image/kfr.png', "touser": this.info.friendId, // 接收人姓名
"toname": this.info.chatName, // 接收人 "content": cell.content,
"touser": this.info.friendId, // 接收人姓名 "time": cell.type==3?5:0,
"content": cell.content, "ifaudio":cell.type==3? true:false,
"time": cell.type==3?5:0, "fromtime": cell.sendTime,
"ifaudio":cell.type==3? true:false, "type": data.type==0?'txt':(data.type==1?'image':data.type==3?'audio':(data.type==4?'video':(data.type==5?'order':(data.type==6?'product':'')))),
"fromtime": cell.sendTime, "id": cell.id,
"type": data.type==0?'txt':(data.type==1?'image':data.type==3?'audio':(data.type==4?'video':(data.type==5?'order':(data.type==6?'product':'')))), "recvId": cell.recvId,
"id": cell.id, "sendId": cell.sendId,
"recvId": cell.recvId, };
"sendId": cell.sendId, this.unshiftmsg.unshift(mdata);
}; });
this.unshiftmsg.unshift(mdata);
});
if(ii==2){
// 跳转到加载数据的第一条 与前面的:id进行对照
setTimeout(() => {
that.screendo(gotonum -1);
}, 100);
}
else{
// 跳转到最后一条数据 与前面的:id进行对照 // 跳转到最后一条数据 与前面的:id进行对照
setTimeout(() => { setTimeout(() => {
that.screendo(that.unshiftmsg.length-1); that.screendo(that.unshiftmsg.length-1);
}, 100); }, 100);
}
// 缓存聊天
myCache(this.info.chatId,this.unshiftmsg);
this.info.minId=this.unshiftmsg[this.unshiftmsg.length-1].id;
this.$forceUpdate();
// 离线加载后更新聊天列表记录 // 缓存聊天
var chatlastinfo={ myCache(this.info.chatId,this.unshiftmsg);
id: this.info.chatId, this.info.minId=this.unshiftmsg[this.unshiftmsg.length-1].id;
content:this.unshiftmsg[this.unshiftmsg.length-1].content, // 保存最大拉取Id
type: type, // this.savaMaxId({id:this.info.chatId,minId:this.info.minId});
minId: this.unshiftmsg[this.unshiftmsg.length-1].id, this.$forceUpdate();
datetime: this.unshiftmsg[this.unshiftmsg.length-1].sendTime,
name: this.info.chatName, // 离线加载后更新聊天列表记录
userid: this.userid, var chatlastinfo={
fromuser: this.info.friendId, id: this.info.chatId,
img: this.info.chatAvatar, content:this.unshiftmsg[this.unshiftmsg.length-1].content,
sort:"privatechat" type: type,
}; minId: this.unshiftmsg[this.unshiftmsg.length-1].id,
this.updateChatList(chatlastinfo); datetime: this.unshiftmsg[this.unshiftmsg.length-1].sendTime,
name: this.info.chatName,
userid: this.userid,
fromuser: this.info.friendId,
img: this.info.chatAvatar,
sort:"privatechat"
};
this.updateChatList(chatlastinfo);
// 已读操作
this.readed();
}
// }
}
}, },
screendo(scrindex){ screendo(scrindex){
this.scrollToView = ''; this.scrollToView = '';
@ -785,7 +843,7 @@
// 自定义下拉刷新被触发 // 自定义下拉刷新被触发
onRefresh(event){ onRefresh(event){
// 加载聊天记录 // 加载聊天记录
this.readUp(2); this.getList();
}, },
// 自定义下拉刷新被复位 // 自定义下拉刷新被复位
onRestore() { onRestore() {
@ -1103,6 +1161,10 @@
this.$forceUpdate(); this.$forceUpdate();
// 缓存聊天 // 缓存聊天
myCache(this.info.chatId,this.unshiftmsg); myCache(this.info.chatId,this.unshiftmsg);
this.info.minId=this.unshiftmsg[this.unshiftmsg.length-1].id;
this.$forceUpdate();
// 保存最大拉取Id
// this.savaMaxId({id:this.info.chatId,minId:this.info.minId});
// 更新聊天列表记录 // 更新聊天列表记录
var chatlastinfo={ var chatlastinfo={
id:this.info.chatId, id:this.info.chatId,
@ -1162,6 +1224,19 @@
myCache("chatlist-"+this.userid,chatlist); myCache("chatlist-"+this.userid,chatlist);
} }
}, },
// 更新是否已读
updateRead(item){
console.log("updateRead")
this.unshiftmsg.forEach((cell,index)=>{
// console.log(cell,item.recvId)
if(cell.fromuser==item.recvId){
this.unshiftmsg[index].ifread=true;
this.$forceUpdate();
}
});
// 缓存聊天
myCache(this.info.chatId,this.unshiftmsg);
},
//输入框高度 //输入框高度
heights(e) { heights(e) {
this.inputh = e; this.inputh = e;
@ -1246,19 +1321,23 @@
} }
.message { .message {
flex: none; flex: none;
max-width: 480rpx; max-width: 540rpx;
display: flex;
flex-direction: row;
} }
.messagevideo { .messagevideo {
max-width: 480rpx; max-width: 540rpx;
height: 300rpx; height: 300rpx;
display: flex;
flex-direction: row;
} }
.msg-text { .msg-text {
font-size: 32rpx; font-size: 32rpx;
color: rgba(39, 40, 50, 1); color: rgba(39, 40, 50, 1);
line-height: 44rpx; line-height: 44rpx;
padding: 18rpx 24rpx; padding: 18rpx 24rpx;
word-break: break-all;
} }
.msg-img { .msg-img {
max-width: 400rpx; max-width: 400rpx;
border-radius: 20rpx; border-radius: 20rpx;
@ -1337,6 +1416,7 @@
margin-left: 16rpx; margin-left: 16rpx;
background-color: #fff; background-color: #fff;
border-radius: 0rpx 20rpx 20rpx 20rpx; border-radius: 0rpx 20rpx 20rpx 20rpx;
word-break: break-all;
} }
.ms-img { .ms-img {
@ -1497,6 +1577,22 @@
.msg-right { .msg-right {
flex-direction: row-reverse; flex-direction: row-reverse;
.read{
font-size: 24rpx;
color: #888;
margin-right: 10rpx;
display: flex;
justify-content: flex-end;
align-items: flex-end;
}
.noread{
font-size: 24rpx;
color: #00a89b;
margin-right: 10rpx;
display: flex;
justify-content: flex-end;
align-items: flex-end;
}
.feed-imgy{ .feed-imgy{
display: flex; display: flex;
flex-direction: column; flex-direction: column;
@ -1523,6 +1619,7 @@
font-size: 32rpx; font-size: 32rpx;
color: #FFFFFF; color: #FFFFFF;
line-height: 48rpx; line-height: 48rpx;
word-break: break-all;
border-radius: 20rpx 0rpx 20rpx 20rpx; border-radius: 20rpx 0rpx 20rpx 20rpx;
} }

333
pages/chat/groupchat.vue
Unescape View File

@ -90,19 +90,29 @@
<text class="uname">{{item.fromname}}</text> <text class="uname">{{item.fromname}}</text>
</view> </view>
<view v-if="item.type == 'txt'" class="message"> <view v-if="item.type == 'txt'" class="message">
<view v-if="item.ifread" class="read">已读</view>
<view v-else class="noread">{{item.readedCount?(2-item.readedCount):2}}未读</view>
<view class="msg-text"> <view class="msg-text">
<text selectable>{{item.content}}</text> <text selectable>{{item.content}}</text>
</view> </view>
</view> </view>
<view v-if="item.type == 'image'" @tap="previewImg(item.content)" class="message"> <view v-if="item.type == 'image'" @tap="previewImg(item.content)" class="message">
<view v-if="item.ifread" class="read">已读</view>
<view v-else class="noread">{{item.readedCount?(2-item.readedCount):2}}未读</view>
<image :src="item.content" class="msg-img" mode="widthFix"></image> <image :src="item.content" class="msg-img" mode="widthFix"></image>
</view> </view>
<view v-if="item.type == 'video'" class="messagevideo"> <view v-if="item.type == 'video'" class="messagevideo">
<view v-if="item.ifread" class="read">已读</view>
<view v-else class="noread">{{item.readedCount?(2-item.readedCount):2}}未读</view>
<!-- 视频 --> <!-- 视频 -->
<myVideo :videoUrl="item.content"></myVideo> <myVideo :videoUrl="item.content"></myVideo>
</view> </view>
<view v-if="item.type == 'audio'" @click="playVoice(item.content,item.ifaudio,index)" class="message"> <view v-if="item.type == 'audio'" @click="playVoice(item.content,item.ifaudio,index)" class="message">
<view v-if="item.ifread" class="read">已读</view>
<view v-else class="noread">{{item.readedCount?(2-item.readedCount):2}}未读</view>
<!-- 音频 --> <!-- 音频 -->
<view v-if="item.ifread" class="read">已读</view>
<view v-else class="noread">{{item.readedCount?(2-item.readedCount):2}}未读</view>
<view class="msg-text voice" :style="{width: item.time>2? item.time*40+'rpx' :'auto'}"> <view class="msg-text voice" :style="{width: item.time>2? item.time*40+'rpx' :'auto'}">
{{item.time}}″ {{item.time}}″
<view class="voicel" v-if="item.ifaudio" > <view class="voicel" v-if="item.ifaudio" >
@ -112,6 +122,8 @@
</view> </view>
</view> </view>
<view v-if="item.type == 'product'" class="message" > <view v-if="item.type == 'product'" class="message" >
<view v-if="item.ifread" class="read">已读</view>
<view v-else class="noread">{{item.readedCount?(2-item.readedCount):2}}未读</view>
<view v-if="item.send" class="msg-product" @click="gotoDetail(item)"> <view v-if="item.send" class="msg-product" @click="gotoDetail(item)">
<view v-if="item.send.type==3" class="zx"> <view v-if="item.send.type==3" class="zx">
<view class="zxname">订单咨询</view> <view class="zxname">订单咨询</view>
@ -349,15 +361,15 @@
this.sendinfo=null; this.sendinfo=null;
this.$forceUpdate(); this.$forceUpdate();
} }
// 先获取聊天记录缓存
this.getchatstore();
// 获取客服 和 教练 头像和名称
this.getrwinfo();
} }
}, },
onShow() { onShow() {
// 先获取聊天记录缓存
this.getchatstore();
// 获取客服 和 教练 头像和名称
this.getrwinfo();
// 跳转到最后一条数据 与前面的:id进行对照 // 跳转到最后一条数据 与前面的:id进行对照
setTimeout(() => { setTimeout(() => {
console.log("onShow") console.log("onShow")
@ -368,18 +380,16 @@
if(this.heartbeatInterval){ if(this.heartbeatInterval){
clearInterval(this.heartbeatInterval); // 停止心跳包发送 clearInterval(this.heartbeatInterval); // 停止心跳包发送
} }
// socket接收实时消息
this.socketinit();
}, },
onBackPress(options) { onBackPress(options) {
if (options.from === 'backbutton') { if (options.from === 'backbutton') {
// 来自顶部菜单的返回按钮 // 来自顶部菜单的返回按钮
// 在这里处理你的逻辑 // 在这里处理你的逻辑
console.log('返回按钮被点击'); console.log('返回按钮被点击');
this.closeWebSocket(); // this.closeWebSocket();
uni.onSocketClose(function (res) { // uni.onSocketClose(function (res) {
console.log('WebSocket 已关闭！'); // console.log('WebSocket 已关闭！');
}); // });
return false; return false;
} }
}, },
@ -393,8 +403,8 @@
beforeDestroy() { beforeDestroy() {
console.log('界面关闭socket，beforeDestroy'); console.log('界面关闭socket，beforeDestroy');
// 在组件销毁前，确保关闭 WebSocket 连接 // 在组件销毁前，确保关闭 WebSocket 连接
this.closeWebSocket(); // this.closeWebSocket();
clearInterval(this.heartbeatInterval); // 停止心跳包发送 // clearInterval(this.heartbeatInterval); // 停止心跳包发送
}, },
methods: { methods: {
// 获取客服和教练信息 // 获取客服和教练信息
@ -499,9 +509,9 @@
getchatstore(){ getchatstore(){
var that=this; var that=this;
try{ try{
this.unshiftmsg=[];
// 先获取会话缓存 // 先获取会话缓存
var data= myCache(this.info.chatId)?myCache(this.info.chatId):[]; var data= myCache(this.info.chatId)?myCache(this.info.chatId):[];
console.log("data",data)
data.forEach((cell,i)=>{ data.forEach((cell,i)=>{
cell["ifaudio"]=false; cell["ifaudio"]=false;
//时间间隔处理 //时间间隔处理
@ -565,30 +575,39 @@
]; ];
this.$forceUpdate(); this.$forceUpdate();
} }
// 如果是第一次接收消息没有缓存，且有minId则拉取离线消息
if(this.info.minId){
this.readUp(1);
}
} }
else{ else{
// 跳转到最后一条数据 与前面的:id进行对照 // 跳转到最后一条数据 与前面的:id进行对照
setTimeout(() => { setTimeout(() => {
that.screendo(that.unshiftmsg.length-1); that.screendo(that.unshiftmsg.length-1);
}, 100); }, 100);
// 已经有缓存，则拉取离线消息
this.info.minId=this.unshiftmsg[this.unshiftmsg.length-1].id;
this.$forceUpdate();
// 请求服务器加载加载拉取离线聊天记录
if(this.info.minId&&this.info.minId>0){
this.readUp(1);
}
} }
} }
catch(err){ catch(err){
console.log(err); console.log(err);
} }
// socket接收实时消息
this.socketinit();
},
// 是否是列表中已经存在了minId
ifpull(){
var ret=true;
this.unshiftmsg.forEach((cell)=>{
if(cell.id&&this.info.minId&&parseInt(cell.id)>=parseInt(this.info.minId)){
ret=false;
}
});
return ret;
},
ifadd(id){
var ret=true;
this.unshiftmsg.forEach((cell)=>{
if(cell.id==id){
ret=false;
}
});
return ret;
}, },
// 定时心跳包 // 定时心跳包
startHeartbeat() { startHeartbeat() {
@ -626,6 +645,8 @@
}, },
success: (res) => { success: (res) => {
console.log(res, 'socket连接成功success'); console.log(res, 'socket连接成功success');
// 获取当前聊天中的minId 拉取离线信息
that.getReadedId();
}, },
fail: (res) => { fail: (res) => {
console.log(res, 'socket连接失败') console.log(res, 'socket连接失败')
@ -666,18 +687,29 @@
// 群聊 // 群聊
if(data.data){ if(data.data){
data=data.data; data=data.data;
// 是此群聊发送来的消息 // 是此群聊发送来的消息
if(data.groupId==this.info.groupId){ if(data.groupId==this.info.groupId){
// 加入聊天记录 if(this.ifadd(data.id)){
// 消息类型 0:文字 1:图片 2:文件 3:语音 4:视频 5 订单 6 商品 10, "撤回" 11, "已读 "12, "消息已读回执 " 30,"加载中标记" // 加入聊天记录
if(data.type==0||data.type==1||data.type==2||data.type==3||data.type==4||data.type==5||data.type==6){ // 消息类型 0:文字 1:图片 2:文件 3:语音 4:视频 5 订单 6 商品 10, "撤回" 11, "已读 "12, "消息已读回执 " 30,"加载中标记"
this.getMsgSender(data) if(data.type==0||data.type==1||data.type==2||data.type==3||data.type==4||data.type==5||data.type==6){
this.getMsgSender(data);
// 已读操作
this.readed();
}
else{
// 10, "撤回" 11, "已读 " 12, "消息已读回执 " 30,"加载中标记"
}
} }
else{ // 10, "撤回" 11, "已读 " 12, "消息已读回执 " 30,"加载中标记"
// 10, "撤回" 11, "已读 " 12, "消息已读回执 " 30,"加载中标记" if(data.type==12){
// 已读操作
this.updateRead(data);
} }
} }
} }
} }
} }
}); });
@ -742,6 +774,8 @@
// 缓存聊天 // 缓存聊天
myCache(this.info.chatId,this.unshiftmsg); myCache(this.info.chatId,this.unshiftmsg);
// 保存最大拉取Id
this.savaMaxId({id:this.info.chatId,minId:data.id});
// 接收到socket后更新聊天列表记录 // 接收到socket后更新聊天列表记录
var chatlastinfo={ var chatlastinfo={
@ -764,6 +798,27 @@
// 已读操作 // 已读操作
this.readed(); this.readed();
}, },
savaMaxId(info){
// 保存最大拉取Id
var data= myCache("groupMsgMaxId")?myCache("groupMsgMaxId"):[];
console.log("data",data)
var ifhas=0;
data.forEach((cell,i)=>{
if(cell.id==info.id){
ifhas=1;
data[i].minId==info.minId;
}
});
if(ifhas){
// 如果存在信息修改
myCache("groupMsgMaxId",data);
}
else{
// 如果不存在信息添加
data.push(info);
myCache("groupMsgMaxId",data);
}
},
async getProduct(id){ async getProduct(id){
console.log("getProduct",id) console.log("getProduct",id)
var rets=null; var rets=null;
@ -812,93 +867,102 @@
async readed() { async readed() {
const {data: res} = await uni.$http.put('/api/message/group/readed?groupId='+this.info.groupId); const {data: res} = await uni.$http.put('/api/message/group/readed?groupId='+this.info.groupId);
}, },
// 已读推送 // 获取当前聊天中最大minId
async readUp(ii) { async getReadedId() {
const {data: res} = await uni.$http.put('/api/message/group/readed?groupId='+this.info.groupId); const {data: res} = await uni.$http.get('/api/message/group/maxReadedId',{groupId:this.info.groupId});
this.getList(ii); if(res.data){
this.info.minId=res.data;
this.$forceUpdate();
this.getList();
}
}, },
// 加载对话 // 加载对话
async getList(ii) { async getList() {
var that=this; // if(this.ifpull()){
const {data: res} = await uni.$http.get('/api/message/group/pullOfflineMessage',{minId: this.info.minId}); var that=this;
this.triggered = false; const {data: res} = await uni.$http.get('/api/message/group/pullOfflineMessage',{minId: this.info.minId});
if(res.data&&res.data.length>0){ this.triggered = false;
const gotonum=res.data.length; if(res.data&&res.data.length>0){
var type=0; const gotonum=res.data.length;
res.data.forEach((cell,i)=>{ var type=0;
type=cell.type; res.data.forEach((cell,i)=>{
cell["ifaudio"]=false; if(this.ifadd(cell.id)){
//时间间隔处理 type=cell.type;
if (i < this.unshiftmsg.length - 1) { cell["ifaudio"]=false;
//这里表示头部时间还是显示一下 //时间间隔处理
let t = dateTime.spaceTime(this.oldTime, cell.fromtime); if (i < this.unshiftmsg.length - 1) {
if (t) { //这里表示头部时间还是显示一下
this.oldTime = t; let t = dateTime.spaceTime(this.oldTime, cell.fromtime);
if (t) {
this.oldTime = t;
}
cell.fromtime = t;
}
// 获取图片，为下面的预览做准备
if (cell.type == 1) {
this.imgMsg.unshift(cell.content)
}
else if(cell.type==0){
cell.content=decodeURIComponent(cell.content);
}
// // 消息类型 0:文字 1:图片 2:文件 3:语音 4:视频 5 订单 6 商品 10, "撤回" 11, "已读 "12, "消息已读回执 " 30,"加载中标记"
let mdata = {
"fromname": this.userName,
"fromuser": this.userid,
"headimg": cell.headImage?cell.headImage:'/static/image/kfr.png',
"toname": cell.sendNickName, // 接收人
"touser": cell.sendId, // 接收人姓名
"content": cell.content,
"readedCount": cell.readedCount,
"time": cell.type==3?5:0,
"ifaudio":cell.type==3? true:false,
"fromtime": cell.sendTime,
"type": data.type==0?'txt':(data.type==1?'image':data.type==3?'audio':(data.type==4?'video':(data.type==5?'order':(data.type==6?'product':'')))),
"id": cell.id,
"sendId": cell.sendId,
"atUserIds": data.atUserIds,
};
this.unshiftmsg.unshift(mdata);
} }
cell.fromtime = t; });
} // // 跳转到加载数据的第一条 与前面的:id进行对照
// 获取图片，为下面的预览做准备 // setTimeout(() => {
if (cell.type == 1) { // that.screendo(gotonum -1);
this.imgMsg.unshift(cell.content) // }, 100);
}
else if(cell.type==0){
cell.content=decodeURIComponent(cell.content);
}
// // 消息类型 0:文字 1:图片 2:文件 3:语音 4:视频 5 订单 6 商品 10, "撤回" 11, "已读 "12, "消息已读回执 " 30,"加载中标记"
let mdata = {
"fromname": this.userName,
"fromuser": this.userid,
"headimg": cell.headImage?cell.headImage:'/static/image/kfr.png',
"toname": cell.sendNickName, // 接收人
"touser": cell.sendId, // 接收人姓名
"content": cell.content,
"readedCount": cell.readedCount,
"time": cell.type==3?5:0,
"ifaudio":cell.type==3? true:false,
"fromtime": cell.sendTime,
"type": data.type==0?'txt':(data.type==1?'image':data.type==3?'audio':(data.type==4?'video':(data.type==5?'order':(data.type==6?'product':'')))),
"id": cell.id,
"sendId": cell.sendId,
"atUserIds": data.atUserIds,
};
this.unshiftmsg.unshift(mdata);
});
if(ii==2){
// 跳转到加载数据的第一条 与前面的:id进行对照
setTimeout(() => {
that.screendo(gotonum -1);
}, 100);
}
else{
// 跳转到最后一条数据 与前面的:id进行对照 // 跳转到最后一条数据 与前面的:id进行对照
setTimeout(() => { setTimeout(() => {
that.screendo(that.unshiftmsg.length-1); that.screendo(that.unshiftmsg.length-1);
}, 100); }, 100);
} // 缓存聊天
// 缓存聊天 myCache(this.info.chatId,this.unshiftmsg);
myCache(this.info.chatId,this.unshiftmsg); this.info.minId=this.unshiftmsg[this.unshiftmsg.length-1].id;
this.info.minId=this.unshiftmsg[this.unshiftmsg.length-1].id; this.$forceUpdate();
this.$forceUpdate(); // 保存最大拉取Id
this.savaMaxId({id:this.info.chatId,minId:this.info.minId});
// 离线加载后更新聊天列表记录 // 离线加载后更新聊天列表记录
var chatlastinfo={ var chatlastinfo={
id: this.info.chatId, id: this.info.chatId,
groupId:this.info.groupId, groupId:this.info.groupId,
content:this.unshiftmsg[this.unshiftmsg.length-1].content, content:this.unshiftmsg[this.unshiftmsg.length-1].content,
type: type, type: type,
minId: this.unshiftmsg[this.unshiftmsg.length-1].id, minId: this.unshiftmsg[this.unshiftmsg.length-1].id,
datetime: this.unshiftmsg[this.unshiftmsg.length-1].sendTime, datetime: this.unshiftmsg[this.unshiftmsg.length-1].sendTime,
name: this.info.chatName, name: this.info.chatName,
userid: this.userid, userid: this.userid,
friendId: this.info.friendId, // 客服userid friendId: this.info.friendId, // 客服userid
teacherId: this.info.teacherId? this.info.teacherId:this.info.instructor, // 教练userid teacherId: this.info.teacherId? this.info.teacherId:this.info.instructor, // 教练userid
fromuser: this.unshiftmsg[this.unshiftmsg.length-1].touser, fromuser: this.unshiftmsg[this.unshiftmsg.length-1].touser,
img: this.unshiftmsg[this.unshiftmsg.length-1].headimg, img: this.unshiftmsg[this.unshiftmsg.length-1].headimg,
sort:"groupchat" sort:"groupchat"
}; };
this.updateChatList(chatlastinfo); this.updateChatList(chatlastinfo);
// 已读操作
this.readed();
}
// }
}
}, },
screendo(scrindex){ screendo(scrindex){
this.scrollToView = ''; this.scrollToView = '';
@ -922,7 +986,7 @@
// 自定义下拉刷新被触发 // 自定义下拉刷新被触发
onRefresh(event){ onRefresh(event){
// 加载聊天记录 // 加载聊天记录
this.readUp(2); this.getList();
}, },
// 自定义下拉刷新被复位 // 自定义下拉刷新被复位
onRestore() { onRestore() {
@ -1240,6 +1304,9 @@
this.$forceUpdate(); this.$forceUpdate();
// 缓存聊天 // 缓存聊天
myCache(this.info.chatId,this.unshiftmsg); myCache(this.info.chatId,this.unshiftmsg);
// 保存最大拉取Id
this.savaMaxId({id:this.info.chatId,minId:rrdata.id});
// 更新聊天列表记录 // 更新聊天列表记录
var chatlastinfo={ var chatlastinfo={
id:this.info.chatId, id:this.info.chatId,
@ -1302,6 +1369,21 @@
myCache("chatlist-"+this.userid,chatlist); myCache("chatlist-"+this.userid,chatlist);
} }
}, },
// 更新是否已读
updateRead(item){
console.log(this.info)
this.unshiftmsg.forEach((cell,index)=>{
if(cell.id==item.id){
this.unshiftmsg[index].readedCount=item.readedCount;
if(item.readedCount>=2){
this.unshiftmsg[index].ifread=true;
}
this.$forceUpdate();
}
});
// 缓存聊天
myCache(this.info.chatId,this.unshiftmsg);
},
//输入框高度 //输入框高度
heights(e) { heights(e) {
this.inputh = e; this.inputh = e;
@ -1386,11 +1468,15 @@
} }
.message { .message {
flex: none; flex: none;
max-width: 480rpx; max-width: 540rpx;
display: flex;
flex-direction: row;
} }
.messagevideo { .messagevideo {
max-width: 480rpx; max-width: 540rpx;
height: 300rpx; height: 300rpx;
display: flex;
flex-direction: row;
} }
.msg-text { .msg-text {
font-size: 32rpx; font-size: 32rpx;
@ -1637,6 +1723,23 @@
.msg-right { .msg-right {
flex-direction: row-reverse; flex-direction: row-reverse;
.read{
font-size: 24rpx;
color: #888;
margin-right: 10rpx;
display: flex;
justify-content: flex-end;
align-items: flex-end;
}
.noread{
font-size: 24rpx;
color: #00a89b;
margin-right: 10rpx;
display: flex;
justify-content: flex-end;
align-items: flex-end;
}
.feed-imgy{ .feed-imgy{
display: flex; display: flex;
flex-direction: column; flex-direction: column;

7
pages/index/index.vue
Unescape View File

@ -781,6 +781,13 @@
.thname{ .thname{
font-size: 30rpx; font-size: 30rpx;
color:#000; color:#000;
display: -webkit-box;
-webkit-box-orient: vertical;
overflow: hidden;
text-overflow: ellipsis;
/* 假设你的行高是20px，并且你想要两行显示 */
line-height: 40rpx; /* 每行的行高 */
max-height: 80rpx;
} }
.thtext{ .thtext{
margin-top: 10rpx; margin-top: 10rpx;

663
pages/message/group.vue
Unescape View File

@ -12,27 +12,28 @@
<view v-if="grouplist.length==0 && loadStatus=='nomore'" class="nodata">暂无消息~</view> <view v-if="grouplist.length==0 && loadStatus=='nomore'" class="nodata">暂无消息~</view>
<view class="listcell"> <view class="listcell">
<u-swipe-action ref="swipeRef" :options="options" v-for="(info, index) in grouplist" :key="index" @click="$u.throttle(actionClick(info,index), 2000)" > <u-swipe-action ref="swipeRef" :options="options" v-for="(info, index) in grouplist" :key="info.id" style="min-width: 600rpx;"
<view class="lcon" @click="gotoGroup(info,index)" :key="index" @longpress="handleLongPress(info,index)"> @click="$u.throttle(actionClick(info,index), 2000)">
<view class="limg"> <view class="lcon" @click="gotoGroup(info,index)" :key="index" @longpress="handleLongPress(info,index)">
<image class="img" :src="info.img" mode="aspectFill"></image> <view class="limg">
<image class="img" :src="info.img" mode="aspectFill"></image>
</view>
<view class="lright">
<view class="lrow">
<view class="pname">{{info.name}}</view>
<view class="ptime"> {{ changeTime(info.datetime)}}</view>
</view> </view>
<view class="lright"> <view class="lrow">
<view class="lrow"> <view class="pnr">
<view class="pname">{{info.name}}</view> {{ info.type==0?info.content:(info.type==1?"图片":(info.type==2?"文件":(info.type==3?"语音":(info.type==4?"视频":
<view class="ptime"> {{ changeTime(info.datetime)}}</view> (info.type==5?"订单咨询":(info.type==6?"商品咨询":info.content))))))}}
</view> </view>
<view class="lrow"> <view class="lnum" v-if="info.sl>0">
<view class="pnr"> {{ info.sl}}
{{ info.type==0?info.content:(info.type==1?"图片":(info.type==2?"文件":(info.type==3?"语音":(info.type==4?"视频":
(info.type==5?"订单咨询":(info.type==6?"商品咨询":info.content))))))}}
</view>
<view class="lnum" v-if="info.sl>0">
{{ info.sl}}
</view>
</view> </view>
</view> </view>
</view> </view>
</view>
</u-swipe-action> </u-swipe-action>
@ -71,7 +72,7 @@
backgroundColor: '#ed2a28' backgroundColor: '#ed2a28'
} }
} }
], //u-swipe-action样式 ], // u-swipe-action样式
imgurl:uni.$http.baseUrl, imgurl:uni.$http.baseUrl,
grouplist:[], grouplist:[],
socketTask: null, socketTask: null,
@ -82,8 +83,6 @@
} }
}, },
onLoad(options) { onLoad(options) {
// socket接收信息初始化
// this.socketinit();
}, },
onShow(){ onShow(){
this.openId = myCache('openId'); this.openId = myCache('openId');
@ -110,18 +109,18 @@
// 来自顶部菜单的返回按钮 // 来自顶部菜单的返回按钮
// 在这里处理你的逻辑 // 在这里处理你的逻辑
console.log('返回按钮被点击'); console.log('返回按钮被点击');
this.closeWebSocket(); // this.closeWebSocket();
uni.onSocketClose(function (res) { // uni.onSocketClose(function (res) {
console.log('WebSocket 已关闭！'); // console.log('WebSocket 已关闭！');
}); // });
return false; return false;
} }
}, },
beforeDestroy() { beforeDestroy() {
console.log('界面关闭socket，beforeDestroy'); console.log('界面关闭socket，beforeDestroy');
// 在组件销毁前，确保关闭 WebSocket 连接 // 在组件销毁前，确保关闭 WebSocket 连接
this.closeWebSocket(); // this.closeWebSocket();
clearInterval(this.heartbeatInterval); // 停止心跳包发送 // clearInterval(this.heartbeatInterval); // 停止心跳包发送
}, },
beforeRouteLeave(to, from, next) { beforeRouteLeave(to, from, next) {
console.log('界面关闭socket，beforeRouteLeave'); console.log('界面关闭socket，beforeRouteLeave');
@ -130,22 +129,7 @@
methods: { methods: {
handleLongPress(info,index) { handleLongPress(info,index) {
console.log(index); console.log(index);
this.$refs.swipeRef[index].open() this.$refs.swipeRef[index].open();
// var that=this;
// uni.showModal({
// title: '提示',
// content: "确定要删除此聊天记录吗？",
// cancelText: '取消',
// confirmText: '确定',
// success: ress => {
// if (ress.confirm) {
// // myCache(info.id,"");
// // that.grouplist.splice(index, 1);
// // that.$forceUpdate();
// // myCache("chatlist-"+this.userid,that.grouplist);
// }
// }
// });
}, },
// 删除 // 删除
actionClick(info,index) { actionClick(info,index) {
@ -158,6 +142,7 @@
confirmText: '确定', confirmText: '确定',
success: ress => { success: ress => {
if (ress.confirm) { if (ress.confirm) {
that.$refs.swipeRef[index].close();
myCache(info.id,""); myCache(info.id,"");
that.grouplist.splice(index, 1); that.grouplist.splice(index, 1);
that.$forceUpdate(); that.$forceUpdate();
@ -185,182 +170,222 @@
// ws接收消息 // ws接收消息
socketinit(){ socketinit(){
var that = this; var that = this;
// if (!that.isConnected) { that.socketTask=uni.connectSocket({
url: "wss://www.sanduolantoyoga.com/yoga-imserver/",
header: {
// 'content-type': 'application/json',
Authorization: uni.getStorageSync("token"),
},
success: (res) => {
console.log(res, 'socket连接成功success');
},
fail: (res) => {
console.log(res, 'socket连接失败')
},
complete: (res) => {
console.log(res,'socket连接成功complete');
}
});
that.socketTask=uni.connectSocket({ uni.onSocketOpen(resopen => {
url: "wss://www.sanduolantoyoga.com/yoga-imserver/", console.log('WebSocket连接已打开！');
header: { that.isConnected = true;
// 'content-type': 'application/json', that.$forceUpdate();
Authorization: uni.getStorageSync("token"), uni.sendSocketMessage({
}, data: JSON.stringify({
success: (res) => { "cmd": 0,//心跳
console.log(res, 'socket连接成功success'); "data": {
}, "accessToken":uni.getStorageSync("token"),
fail: (res) => { },
console.log(res, 'socket连接失败') }), // 发送心跳包数据 // 发送的消息内容
success(re) {
console.log(re);
console.log('消息发送成功！')
}, },
complete: (res) => { fail(err) {
console.log(res,'socket连接成功complete'); console.log(err);
console.log('消息发送失败！')
} }
}); });
uni.onSocketOpen(resopen => { // 定时发送心跳包
console.log('WebSocket连接已打开！'); this.startHeartbeat();
that.isConnected = true;
that.$forceUpdate() // 拉取离线消息
uni.sendSocketMessage({ this.grouplist.forEach((cell,i)=>{
data: JSON.stringify({ if(cell.minId){
"cmd": 0,//心跳 // 通过某个会话中已读消息的最大id 获取离线消息
"data": { this.pullMessage(i,cell);
"accessToken":uni.getStorageSync("token"), }
}, });
}), // 发送心跳包数据 // 发送的消息内容
success(re) { // 已经删除的有最大id的继续拉取是否有消息
console.log(re); var data= myCache("privateMsgMaxId")?myCache("privateMsgMaxId"):[{id:0,minId:0}];
console.log('消息发送成功！') data.forEach((cell)=>{
}, console.log("privateMsgMaxId")
fail(err) { var ifcz=false;
console.log(err); this.grouplist.forEach((item)=>{
console.log('消息发送失败！') if(cell.id==item.id){
// 已经存在列表了，不用拉取离线信息
ifcz=true;
} }
}); });
if(!ifcz){
// 拉取离线信息
this.getList(cell);
}
});
// 发送心跳包 var data= myCache("groupMsgMaxId")?myCache("groupMsgMaxId"):[{id:0,minId:0}];
this.startHeartbeat(); data.forEach((cell)=>{
var ifcz=false;
this.grouplist.forEach((item)=>{
if(cell.id==item.id){
// 已经存在列表了，不用拉取离线信息
ifcz=true;
}
});
if(!ifcz){
// 拉取离线信息
this.getGroupList(cell);
}
}); });
uni.onSocketMessage(res => { });
console.log('收到WebSocket服务器消息：');
if(res.data){
var rs=JSON.parse(res.data);
console.log(rs);
if(rs.cmd==3){
// 私聊
if(rs.data){
var data=rs.data;
if(data.recvId&&(data.recvId).toString()==(that.userid).toString()){
// 是这个用户的接收的私聊信息
// 加入聊天记录
// 消息类型 0:文字 1:图片 2:文件 3:语音 4:视频 10, "撤回" 11, "已读 "12, "消息已读回执 " 30,"加载中标记"
if(data.type==0){
data.content=decodeURIComponent(data.content);
}
if(data.type==0||data.type==1||data.type==2||data.type==3||data.type==4||data.type==5||data.type==6){
var ifexist=0,idx=null;
that.grouplist.forEach((cell,index)=>{
if(cell.fromuser==data.sendId&&cell.userid==data.recvId&&cell.sort=="privatechat"){
ifexist=1;
idx=index;
that.grouplist[index].sl=(that.grouplist[index].sl?that.grouplist[index].sl+1:1);
that.grouplist[index].content=data.content;
that.grouplist[index].datetime=data.sendTime;
that.grouplist[index].type=data.type;
that.$forceUpdate();
}
});
if(ifexist==0){ uni.onSocketMessage(res => {
// 未保存缓存 console.log('收到WebSocket服务器消息：');
// 接收到socket后更新聊天列表记录 if(res.data){
var chatlastinfo={ var rs=JSON.parse(res.data);
id: "privatechat-" + data.recvId +"-" + data.sendId, console.log(rs);
content: data.content, if(rs.cmd==3){
minId: data.id, // 私聊
sl:1, if(rs.data){
datetime: data.sendTime, var data=rs.data;
type: data.type, if(data.recvId&&(data.recvId).toString()==(that.userid).toString()){
name: "", // 是这个用户的接收的私聊信息
userid: data.recvId, // 加入聊天记录
fromuser: data.sendId, // 消息类型 0:文字 1:图片 2:文件 3:语音 4:视频 10, "撤回" 11, "已读 "12, "消息已读回执 " 30,"加载中标记"
img: "", if(data.type==0){
sort:"privatechat" data.content=decodeURIComponent(data.content);
}; }
that.updateChatList(chatlastinfo,ifexist); if(data.type==0||data.type==1||data.type==2||data.type==3||data.type==4||data.type==5||data.type==6){
} var ifexist=0,chatinfo=null;
else{ that.grouplist.forEach((cell,index)=>{
that.updateChatList(that.grouplist[idx],ifexist); if(cell.fromuser==data.sendId&&cell.userid==data.recvId&&cell.sort=="privatechat"){
ifexist=1;
that.grouplist[index].sl=(that.grouplist[index].sl?that.grouplist[index].sl+1:1);
that.grouplist[index].content=data.content;
that.grouplist[index].datetime=data.sendTime;
that.grouplist[index].type=data.type;
that.$forceUpdate();
chatinfo= JSON.parse(JSON.stringify(that.grouplist[index])) ;
console.log(chatinfo)
} }
});
if(ifexist==0){
// 未保存缓存
// 接收到socket后更新聊天列表记录
var chatlastinfo={
id: "privatechat-" + data.recvId +"-" + data.sendId,
content: data.content,
minId: data.id,
sl:1,
datetime: data.sendTime,
type: data.type,
name: "",
userid: data.recvId,
fromuser: data.sendId,
img: "",
sort:"privatechat"
};
that.updateChatList(chatlastinfo);
} }
else{ else{
// 10, "撤回" 11, "已读 " 12, "消息已读回执 " 30,"加载中标记" that.updateChatList(chatinfo);
} }
} }
else{
// 10, "撤回" 11, "已读 " 12, "消息已读回执 " 30,"加载中标记"
}
} }
} }
else if(rs.cmd==4){ }
// 群聊 else if(rs.cmd==4){
if(rs.data){ // 群聊
var data=rs.data; if(rs.data){
if(data.atUserIds&&data.atUserIds.includes(that.userid)){ var data=rs.data;
// 是这个用户的接收的群聊信息 if(data.atUserIds&&data.atUserIds.includes(that.userid)){
// 加入聊天记录 // 是这个用户的接收的群聊信息
// 消息类型 0:文字 1:图片 2:文件 3:语音 4:视频 10, "撤回" 11, "已读 "12, "消息已读回执 " 30,"加载中标记" // 加入聊天记录
if(data.type==0){ // 消息类型 0:文字 1:图片 2:文件 3:语音 4:视频 10, "撤回" 11, "已读 "12, "消息已读回执 " 30,"加载中标记"
data.content=decodeURIComponent(data.content); if(data.type==0){
} data.content=decodeURIComponent(data.content);
if(data.type==0||data.type==1||data.type==2||data.type==3||data.type==4||data.type==5||data.type==6){ }
var ifexist=0,idx=null; if(data.type==0||data.type==1||data.type==2||data.type==3||data.type==4||data.type==5||data.type==6){
that.grouplist.forEach((cell,index)=>{ var ifexist=0,idx=null;
if(cell.groupId==data.groupId&&cell.sort=="groupchat"){ that.grouplist.forEach((cell,index)=>{
ifexist=1; if(cell.groupId==data.groupId&&cell.sort=="groupchat"){
idx=index; ifexist=1;
that.grouplist[index].sl=(that.grouplist[index].sl?that.grouplist[index].sl+1:1); idx=index;
that.grouplist[index].content=data.content; that.grouplist[index].sl=(that.grouplist[index].sl?that.grouplist[index].sl+1:1);
that.grouplist[index].datetime=data.sendTime; that.grouplist[index].content=data.content;
that.grouplist[index].fromuser=data.sendId; that.grouplist[index].datetime=data.sendTime;
that.grouplist[index].type=data.type; that.grouplist[index].fromuser=data.sendId;
that.$forceUpdate(); that.grouplist[index].type=data.type;
} that.$forceUpdate();
});
if(ifexist==0){
// 未保存缓存
// 接收到socket后更新聊天列表记录
var chatlastinfo={
id: "groupchat-" + data.groupId,
groupId:data.groupId,
content: data.content,
minId: data.id,
sl:1,
datetime: data.sendTime,
type: data.type,
name: "",
userid: this.userid,
fromuser: data.sendId,
img: "",
sendId: data.sendId,
sendNickName: data.sendNickName,
sort:"groupchat"
};
that.getGroupInfo(chatlastinfo,ifexist);
}
else{
that.getGroupInfo(that.grouplist[idx],ifexist);
} }
});
if(ifexist==0){
// 未保存缓存
// 接收到socket后更新聊天列表记录
var chatlastinfo={
id: "groupchat-" + data.groupId,
groupId:data.groupId,
content: data.content,
minId: data.id,
sl:1,
datetime: data.sendTime,
type: data.type,
name: "",
userid: this.userid,
fromuser: data.sendId,
img: "",
sendId: data.sendId,
sendNickName: data.sendNickName,
sort:"groupchat"
};
that.getGroupInfo(chatlastinfo);
} }
else{ else{
// 10, "撤回" 11, "已读 " 12, "消息已读回执 " 30,"加载中标记" that.getGroupInfo(that.grouplist[idx]);
} }
} }
else{
// 10, "撤回" 11, "已读 " 12, "消息已读回执 " 30,"加载中标记"
}
} }
} }
} }
}); }
});
uni.onSocketClose(res => { uni.onSocketClose(res => {
console.log('WebSocket连接已关闭！',res); console.log('WebSocket连接已关闭！',res);
that.isConnected = false; that.isConnected = false;
that.$forceUpdate(); that.$forceUpdate();
clearInterval(that.heartbeatInterval); // 停止心跳包发送 clearInterval(that.heartbeatInterval); // 停止心跳包发送
}); });
uni.onSocketError(err => { uni.onSocketError(err => {
console.error('WebSocket连接打开失败，请检查：', err); console.error('WebSocket连接打开失败，请检查：', err);
that.isConnected = false; that.isConnected = false;
that.$forceUpdate(); that.$forceUpdate();
clearInterval(that.heartbeatInterval); // 停止心跳包发送 clearInterval(that.heartbeatInterval); // 停止心跳包发送
}); });
// }
}, },
// 关闭WebSocket连接 // 关闭WebSocket连接
closeWebSocket() { closeWebSocket() {
@ -368,6 +393,16 @@
this.isConnected = false; this.isConnected = false;
this.$forceUpdate() this.$forceUpdate()
}, },
// 消息是否存在列表中
ifadd(id){
var ret=0;
this.grouplist.forEach((cell,ii)=>{
if(cell.id==id){
ret=ii+1;
}
});
return ret;
},
gotoContacts(){ gotoContacts(){
uni.navigateTo({ uni.navigateTo({
url: `/pages/message/contact` url: `/pages/message/contact`
@ -440,21 +475,10 @@
// 获取群聊列表 // 获取群聊列表
async getgroupsmembers(){ async getgroupsmembers(){
// 获取聊天群列表 // 获取聊天群列表
this.grouplist=[]; this.grouplist=myCache("chatlist-"+this.userid)?myCache("chatlist-"+this.userid):[];
var chatlist=myCache("chatlist-"+this.userid)?myCache("chatlist-"+this.userid):[];
chatlist.forEach(cell=>{
if(cell.userid==this.userid){
this.grouplist.push(cell);
}
});
this.grouplist.forEach((cell,i)=>{
if(cell.minId){
// 通过某个会话中已读消息的最大id 获取离线消息
this.readUp(i,cell);
}
});
this.loadStatus="nomore"; this.loadStatus="nomore";
this.$forceUpdate(); this.$forceUpdate();
// 按照时间排序
var that=this; var that=this;
setTimeout(() => { setTimeout(() => {
that.reorder(); that.reorder();
@ -469,68 +493,148 @@
this.grouplist.sort((a, b) => b.datetime - a.datetime); this.grouplist.sort((a, b) => b.datetime - a.datetime);
this.$forceUpdate(); this.$forceUpdate();
}, },
// 已读推送 // 拉取离线信息
async readUp(i,item) { async pullMessage(i,item) {
if(item.sort=="groupchat"){ if(item.sort=="groupchat"){
const {data: res} = await uni.$http.put('/api/message/group/readed?groupId='+item.groupId);
this.getgroupsnums(i,item); this.getgroupsnums(i,item);
} }
else{ else{
const {data: res} = await uni.$http.put('/api/message/private/readed?friendId='+item.fromuser);
this.getgroupsnums(i,item); this.getgroupsnums(i,item);
} }
}, },
// 拉取离线消息
async getGroupList(item) {
// 判断当前 minId 是不是列表中已经存在了，是不再拉取，不是继续拉取
var that=this;
const {data: res} = await uni.$http.get('/api/message/group/pullOfflineMessage',{minId: item.minId});
if(res.data&&res.data.length>0){
res.data.forEach((cell,index)=>{
// 获取消息后对消息进行缓存处理
var chatlastinfo={
id: "groupchat-" + cell.groupId,
groupId:cell.groupId,
content: cell.content,
minId: cell.id,
sl: index+1,
datetime: cell.sendTime,
type: cell.type,
name: "",
userid: this.userid,
fromuser: cell.sendId,
img: "",
sendId: cell.sendId,
sendNickName: cell.sendNickName,
sort:"groupchat"
};
this.getGroupInfo(chatlastinfo,index);
});
}
},
// 拉取离线消息
async getList(item) {
// 判断当前 minId 是不是列表中已经存在了，是不再拉取，不是继续拉取
var that=this;
const {data: res} = await uni.$http.get('/api/message/private/pullOfflineMessage',{minId: item.minId});
if(res.data&&res.data.length>0){
res.data.forEach((cell,index)=>{
// 获取消息后对消息进行缓存处理
var chatlastinfo={
id: "privatechat-" + cell.recvId +"-" + cell.sendId,
content: cell.content,
minId: cell.id,
sl:index+1,
datetime: cell.sendTime,
type: cell.type,
name: "",
userid: cell.recvId,
fromuser: cell.sendId,
img: "",
sort:"privatechat"
};
this.updateChatList(chatlastinfo,index);
});
}
},
ifprivateMsgMaxId(item){
var ret=true;
// 判断当前 minId 是不是列表中已经存在了，是不再拉取，不是继续拉取
var data= myCache("privateMsgMaxId")?myCache("privateMsgMaxId"):[];
data.forEach((cell)=>{
if(cell.id==item.id&&parseInt(item.minId)>=parseInt(cell.minId)){
ret=false;
}
});
return ret;
},
ifgroupMsgMaxId(item){
console.log("ifgroupMsgMaxId")
var ret=true;
// 判断当前 minId 是不是列表中已经存在了，是不再拉取，不是继续拉取
var data= myCache("groupMsgMaxId")?myCache("groupMsgMaxId"):[];
data.forEach((cell)=>{
if(cell.id==item.id&&parseInt(item.minId)>=parseInt(cell.minId)){
ret=false;
}
});
return ret;
},
// 获取群聊中离线信息 // 获取群聊中离线信息
async getgroupsnums(i,item){ async getgroupsnums(i,item){
if(item.sort=="groupchat"){ if(item.sort=="groupchat"){
// 群聊 // 判断当前 minId 是不是列表中已经存在了，是不再拉取，不是继续拉取
const {data: res} = await uni.$http.get("/api/message/group/pullOfflineMessage",{minId:item.minId}); // if(this.ifgroupMsgMaxId(item)){
if(res.data&&res.data.length>0){ // 群聊
// 获取消息后对消息进行缓存处理 const {data: res} = await uni.$http.get("/api/message/group/pullOfflineMessage",{minId:item.minId});
var data=res.data; if(res.data&&res.data.length>0){
// 获取离线消息数量返回 // 获取消息后对消息进行缓存处理
this.grouplist[i]["sl"]=res.data.length; var data=res.data;
var last=res.data[res.data.length-1]; // 获取离线消息数量返回
if(last.type==0){ this.grouplist[i]["sl"]=res.data.length;
last.content=decodeURIComponent(last.content); var last=res.data[res.data.length-1];
} if(last.type==0){
if(last.type==0||last.type==1||last.type==2||last.type==3||last.type==4||data.type==5||data.type==6){ last.content=decodeURIComponent(last.content);
this.grouplist[i].content=last.content; }
this.grouplist[i].type=last.type; if(last.type==0||last.type==1||last.type==2||last.type==3||last.type==4||data.type==5||data.type==6){
this.grouplist[i].datetime=last.datetime; this.grouplist[i].content=last.content;
this.$forceUpdate(); this.grouplist[i].type=last.type;
// 重新排序 this.grouplist[i].datetime=last.datetime;
this.reorder(); this.$forceUpdate();
myCache("chatlist-"+this.userid,this.grouplist); // 重新排序
this.reorder();
myCache("chatlist-"+this.userid,this.grouplist);
}
} }
} // }
} }
else{ else{
// 私聊 // 判断当前 minId 是不是列表中已经存在了，是不再拉取，不是继续拉取
const {data: res} = await uni.$http.get("/api/message/private/pullOfflineMessage",{minId:item.minId}); // if(this.ifprivateMsgMaxId(item)){
if(res.data&&res.data.length>0){ // 私聊
// 获取消息后对消息进行缓存处理 const {data: res} = await uni.$http.get("/api/message/private/pullOfflineMessage",{minId:item.minId});
var data=res.data; if(res.data&&res.data.length>0){
// 获取离线消息数量返回 // 获取消息后对消息进行缓存处理
this.grouplist[i]["sl"]=res.data.length; var data=res.data;
var last=res.data[res.data.length-1]; // 获取离线消息数量返回
if(last.type==0){ this.grouplist[i]["sl"]=res.data.length;
last.content=decodeURIComponent(last.content); var last=res.data[res.data.length-1];
} if(last.type==0){
if(last.type==0||last.type==1||last.type==2||last.type==3||last.type==4||data.type==5||data.type==6){ last.content=decodeURIComponent(last.content);
this.grouplist[i].content=last.content; }
this.grouplist[i].type=last.type; if(last.type==0||last.type==1||last.type==2||last.type==3||last.type==4||data.type==5||data.type==6){
this.grouplist[i].datetime=last.datetime; this.grouplist[i].content=last.content;
this.$forceUpdate(); this.grouplist[i].type=last.type;
// 重新排序 this.grouplist[i].datetime=last.datetime;
this.reorder(); this.$forceUpdate();
myCache("chatlist-"+this.userid,this.grouplist); // 重新排序
this.reorder();
myCache("chatlist-"+this.userid,this.grouplist);
}
} }
} // }
} }
}, },
// 获取群信息 // 获取群信息
async getGroupInfo(info,ifexist) { async getGroupInfo(info) {
const {data: res} = await uni.$http.get('/api/group/find/'+info.groupId); const {data: res} = await uni.$http.get('/api/group/find/'+info.groupId);
if(res.data){ if(res.data){
var data = res.data; var data = res.data;
@ -545,26 +649,34 @@
info.instructor=data.instructor; info.instructor=data.instructor;
info.productId=data.productId; info.productId=data.productId;
info.productName=data.productName; info.productName=data.productName;
this.updateChatGroupList(info,ifexist); this.updateChatGroupList(info);
} }
}, },
async updateChatGroupList(info,ifexist){ async updateChatGroupList(info){
var name=info.name,img=info.img||require("@/static/image/girl.png"); var name=info.name,img=info.img||require("@/static/image/girl.png");
const {data: res} = await uni.$http.get("/api/friend/find/"+info.sendId); const {data: res} = await uni.$http.get("/api/friend/find/"+info.sendId);
if(res.data){ if(res.data){
var data=res.data; var data=res.data;
name=data.nickName?data.nickName:"匿名"; name=data.nickName?data.nickName:"匿名";
img=data.headImage?data.headImage:require("@/static/image/girl.png"); img=data.headImage?data.headImage:require("@/static/image/girl.png");
if(ifexist==0){ var idx=this.ifadd(info.id);
if(!idx){
this.grouplist.push(info); this.grouplist.push(info);
this.$forceUpdate(); this.$forceUpdate();
} }
else{
this.grouplist[idx-1].content=info.content;
this.grouplist[idx-1].datetime=info.datetime;
this.grouplist[idx-1].fromuser=info.fromuser;
this.grouplist[idx-1].type=info.type;
this.$forceUpdate();
}
// 重新排序 保存缓存 // 重新排序 保存缓存
this.reorder(); this.reorder();
myCache("chatlist-"+this.userid,this.grouplist); myCache("chatlist-"+this.userid,this.grouplist);
// 聊天框消息缓存 // 聊天框消息缓存
var msgchat=myCache(info.id); var msgchat=myCache(info.id);
if(ifexist==0||!msgchat){ if(!msgchat){
// 第一条聊天记录保存缓存 // 第一条聊天记录保存缓存
let firstmsg = [{ let firstmsg = [{
"fromname": name, // 发送人 "fromname": name, // 发送人
@ -610,15 +722,23 @@
else{ else{
name="匿名"; name="匿名";
img="../../static/image/girl.png"; img="../../static/image/girl.png";
if(ifexist==0){ var idx=this.ifadd(info.id);
if(!idx){
this.grouplist.push(info); this.grouplist.push(info);
this.$forceUpdate(); this.$forceUpdate();
} }
else{
this.grouplist[idx-1].content=info.content;
this.grouplist[idx-1].datetime=info.datetime;
this.grouplist[idx-1].fromuser=info.fromuser;
this.grouplist[idx-1].type=info.type;
this.$forceUpdate();
}
// 重新排序 // 重新排序
this.reorder(); this.reorder();
myCache("chatlist-"+this.userid,this.grouplist); myCache("chatlist-"+this.userid,this.grouplist);
var msgchat=myCache(info.id); var msgchat=myCache(info.id);
if(ifexist==0||!msgchat){ if(!msgchat){
// 第一条聊天记录保存缓存 // 第一条聊天记录保存缓存
let firstmsg = [{ let firstmsg = [{
"fromname": name, // 发送人 "fromname": name, // 发送人
@ -661,22 +781,31 @@
} }
} }
}, },
async updateChatList(info,ifexist){ async updateChatList(info){
const {data: res} = await uni.$http.get("/api/friend/find/"+info.fromuser); const {data: res} = await uni.$http.get("/api/friend/find/"+info.fromuser);
if(res.data){ if(res.data){
var data=res.data; var data=res.data;
info.name=data.nickName?data.nickName:"匿名"; info.name=data.nickName?data.nickName:"匿名";
info.img=data.headImage?data.headImage:require("@/static/image/girl.png"); info.img=data.headImage?data.headImage:require("@/static/image/girl.png");
if(ifexist==0){ var idx=this.ifadd(info.id);
if(!idx){
this.grouplist.push(info); this.grouplist.push(info);
this.$forceUpdate(); this.$forceUpdate();
} }
else{
// this.grouplist[idx-1].sl=(this.grouplist[idx-1].sl?this.grouplist[idx-1].sl+1:1);
this.grouplist[idx-1].content=info.content;
this.grouplist[idx-1].datetime=info.datetime;
this.grouplist[idx-1].fromuser=info.fromuser;
this.grouplist[idx-1].type=info.type;
this.$forceUpdate();
}
// 重新排序 保存缓存 // 重新排序 保存缓存
this.reorder(); this.reorder();
myCache("chatlist-"+this.userid,this.grouplist); myCache("chatlist-"+this.userid,this.grouplist);
// 聊天框消息缓存 // 聊天框消息缓存
var msgchat=myCache(info.id); var msgchat=myCache(info.id);
if(ifexist==0||!msgchat){ if(!msgchat){
// 第一条聊天记录保存缓存 // 第一条聊天记录保存缓存
let firstmsg = [{ let firstmsg = [{
"fromname": info.name, // 发送人 "fromname": info.name, // 发送人
@ -723,15 +852,26 @@
else{ else{
info.name="匿名"; info.name="匿名";
info.img="../../static/image/girl.png"; info.img="../../static/image/girl.png";
if(ifexist==0){ var idx=this.ifadd(info.id);
if(!idx){
this.grouplist.push(info); this.grouplist.push(info);
this.$forceUpdate(); this.$forceUpdate();
} }
else{
// this.grouplist[idx-1].sl=(this.grouplist[idx-1].sl?this.grouplist[idx-1].sl+1:1);
this.grouplist[idx-1].content=info.content;
this.grouplist[idx-1].datetime=info.datetime;
this.grouplist[idx-1].fromuser=info.fromuser;
this.grouplist[idx-1].type=info.type;
this.$forceUpdate();
}
// 重新排序 // 重新排序
this.reorder(); this.reorder();
myCache("chatlist-"+this.userid,this.grouplist); myCache("chatlist-"+this.userid,this.grouplist);
var msgchat=myCache(info.id); var msgchat=myCache(info.id);
if(ifexist==0||!msgchat){ console.log(info.id,msgchat);
if(!msgchat){
// 第一条聊天记录保存缓存 // 第一条聊天记录保存缓存
let firstmsg = [{ let firstmsg = [{
"fromname": info.name, // 发送人 "fromname": info.name, // 发送人
@ -880,6 +1020,7 @@
background: #fff; background: #fff;
margin: 0; margin: 0;
width: 100%; width: 100%;
min-width: 600rpx;
.lcon{ .lcon{
border-bottom: 1rpx solid #eee; border-bottom: 1rpx solid #eee;
padding-top: 20rpx; padding-top: 20rpx;
@ -939,6 +1080,12 @@
font-family: PingFang SC, PingFang SC; font-family: PingFang SC, PingFang SC;
font-weight: 400; font-weight: 400;
color: #595959; color: #595959;
-webkit-box-orient: vertical;
overflow: hidden;
text-overflow: ellipsis;
/* 假设你的行高是20px，并且你想要两行显示 */
line-height: 40rpx; /* 每行的行高 */
max-height: 40rpx;
} }
.lnum{ .lnum{
background-color: #de0000; background-color: #de0000;

5
pages/user/user.vue
Unescape View File

@ -360,11 +360,6 @@
uni.stopPullDownRefresh() uni.stopPullDownRefresh()
},500); },500);
}, },
// onTabItemTap(){
// console.log('界面关闭socket，onTabItemTap');
// // 在组件销毁前，确保关闭 WebSocket 连接
// uni.closeSocket();
// },
methods: { methods: {
ifview(value){ ifview(value){
// 描述：角色ID；顾问：103 ；教练：104 ；店长：105 ；普通用户：107； // 描述：角色ID；顾问：103 ；教练：104 ；店长：105 ；普通用户：107；

BIN
static/icon/voice.png
View File

Binary file not shown.
Side by Side Swipe Overlay

Before

Width:  |  Height:  |  Size: 1.7 KiB

After

Width:  |  Height:  |  Size: 1.7 KiB

BIN
static/icon/voice0.png
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 1.7 KiB

Write Preview
Loading…
Cancel
Save