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

Compare commits

base: xiaoning:7f5c4fd704d4fc7e9eca679bb527822e8b374fc7
Branches Tags
xiaoning:main
..
compare: xiaoning:23dafaf347f77c2d12178df39618996100343a2c
Branches Tags
xiaoning:main

No commits in common. '7f5c4fd704d4fc7e9eca679bb527822e8b374fc7' and '23dafaf347f77c2d12178df39618996100343a2c' have entirely different histories.
7f5c4fd704 ... 23dafaf347

9 changed files with 562 additions and 911 deletions
Show Stats

14
components/chat/submit.vue
Unescape View File

@ -152,7 +152,7 @@
// }, 0) // }, 0)
// } // }
if (this.msg.length > 0) { if (this.msg.length > 1) {
// 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 > 0) { if (chatm.length > 1) {
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; padding: 14rpx 20rpx;
image { image {
width: 60rpx; width: 56rpx;
height: 60rpx; height: 56rpx;
margin: 0 8rpx; margin: 0 10rpx;
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: 24rpx; font-size: 20rpx;
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.16", "versionName" : "1.0.11",
"versionCode" : 1016, "versionCode" : 1011,
"transformPx" : false, "transformPx" : false,
"app-plus" : { "app-plus" : {
"flexible" : true, "flexible" : true,

195
pages/chat/chat.vue
Unescape View File

@ -90,26 +90,18 @@
<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}}″
@ -120,8 +112,6 @@
</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>
@ -286,13 +276,15 @@
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);
@ -300,24 +292,26 @@
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){
@ -391,12 +385,11 @@
}, },
// 获取聊天记录 // 获取聊天记录
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;
//时间间隔处理 //时间间隔处理
@ -417,6 +410,7 @@
} }
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"){
@ -459,41 +453,30 @@
]; ];
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){
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;
} }
}); catch(err){
return ret; console.log(err);
},
// 消息是否存在列表中
ifadd(id){
var ret=true;
this.unshiftmsg.forEach((cell)=>{
if(cell.id==id){
ret=false;
} }
});
return ret;
}, },
// 定时心跳包 // 定时心跳包
startHeartbeat() { startHeartbeat() {
@ -514,6 +497,7 @@
// 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: {
@ -522,8 +506,6 @@
}, },
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连接失败')
@ -535,7 +517,6 @@
uni.onSocketOpen(res => { uni.onSocketOpen(res => {
console.log('WebSocket连接已打开！'); console.log('WebSocket连接已打开！');
that.isConnected = true; that.isConnected = true;
// 发送登录心跳包 // 发送登录心跳包
uni.sendSocketMessage({ uni.sendSocketMessage({
data: JSON.stringify({ data: JSON.stringify({
@ -553,10 +534,8 @@
console.log('消息发送失败！') console.log('消息发送失败！')
} }
}); });
// 发送心跳包 // 发送心跳包
this.startHeartbeat(); this.startHeartbeat();
}); });
uni.onSocketMessage(res => { uni.onSocketMessage(res => {
console.log('收到WebSocket服务器消息：'); console.log('收到WebSocket服务器消息：');
@ -566,7 +545,6 @@
if(data.data){ if(data.data){
data=data.data; data=data.data;
if(data){ if(data){
if(this.ifadd(data.id)){
// 是发送者发送来的消息 // 是发送者发送来的消息
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()){
// 加入聊天记录 // 加入聊天记录
@ -618,12 +596,6 @@
} }
} }
} }
// 10, "撤回" 11, "已读 " 12, "消息已读回执 " 30,"加载中标记"
if(data.type==12){
// 已读操作
this.updateRead(data);
}
}
} }
} }
}); });
@ -636,6 +608,7 @@
console.error('WebSocket连接打开失败，请检查：', err); console.error('WebSocket连接打开失败，请检查：', err);
clearInterval(that.heartbeatInterval); // 停止心跳包发送 clearInterval(that.heartbeatInterval); // 停止心跳包发送
}); });
}
}, },
// 关闭WebSocket连接 // 关闭WebSocket连接
closeWebSocket() { closeWebSocket() {
@ -648,7 +621,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(() => {
@ -656,29 +629,6 @@
}, 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)
@ -729,25 +679,18 @@
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 getReadedId() { async readUp(ii) {
const {data: res} = await uni.$http.get('/api/message/private/maxReadedId',{friendId:this.info.friendId}); const {data: res} = await uni.$http.put('/api/message/private/readed?friendId='+this.info.friendId);
if(res.data){ this.getList(ii);
this.info.minId=res.data;
this.$forceUpdate();
// 保存最大拉取Id
this.savaMaxId({id:this.info.chatId,minId:this.info.minId});
this.getList();
}
}, },
// 拉取离线消息 // 加载对话
async getList() { async getList(ii) {
// 判断当前 minId 是不是列表中已经存在了，是不再拉取，不是继续拉取
// if(this.ifpull()){
var that=this; var that=this;
const {data: res} = await uni.$http.get('/api/message/private/pullOfflineMessage',{minId: this.info.minId}); const {data: res} = await uni.$http.get('/api/message/private/pullOfflineMessage',{minId: this.info.minId});
this.triggered = false; this.triggered = false;
if(res.data&&res.data.length>0){ if(res.data&&res.data.length>0){
const gotonum=res.data.length;
var type=0; var type=0;
res.data.forEach((cell,i)=>{ res.data.forEach((cell,i)=>{
type=cell.type; type=cell.type;
@ -786,17 +729,21 @@
}; };
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); 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;
// 保存最大拉取Id
// this.savaMaxId({id:this.info.chatId,minId:this.info.minId});
this.$forceUpdate(); this.$forceUpdate();
// 离线加载后更新聊天列表记录 // 离线加载后更新聊天列表记录
@ -814,12 +761,7 @@
}; };
this.updateChatList(chatlastinfo); this.updateChatList(chatlastinfo);
// 已读操作
this.readed();
} }
// }
}, },
screendo(scrindex){ screendo(scrindex){
this.scrollToView = ''; this.scrollToView = '';
@ -843,7 +785,7 @@
// 自定义下拉刷新被触发 // 自定义下拉刷新被触发
onRefresh(event){ onRefresh(event){
// 加载聊天记录 // 加载聊天记录
this.getList(); this.readUp(2);
}, },
// 自定义下拉刷新被复位 // 自定义下拉刷新被复位
onRestore() { onRestore() {
@ -1161,10 +1103,6 @@
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,
@ -1224,19 +1162,6 @@
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;
@ -1321,23 +1246,19 @@
} }
.message { .message {
flex: none; flex: none;
max-width: 540rpx; max-width: 480rpx;
display: flex;
flex-direction: row;
} }
.messagevideo { .messagevideo {
max-width: 540rpx; max-width: 480rpx;
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;
@ -1416,7 +1337,6 @@
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 {
@ -1577,22 +1497,6 @@
.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;
@ -1619,7 +1523,6 @@
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;
} }

189
pages/chat/groupchat.vue
Unescape View File

@ -90,29 +90,19 @@
<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" >
@ -122,8 +112,6 @@
</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>
@ -361,15 +349,15 @@
this.sendinfo=null; this.sendinfo=null;
this.$forceUpdate(); this.$forceUpdate();
} }
}
},
onShow() {
// 先获取聊天记录缓存 // 先获取聊天记录缓存
this.getchatstore(); this.getchatstore();
// 获取客服 和 教练 头像和名称 // 获取客服 和 教练 头像和名称
this.getrwinfo(); this.getrwinfo();
}
},
onShow() {
// 跳转到最后一条数据 与前面的:id进行对照 // 跳转到最后一条数据 与前面的:id进行对照
setTimeout(() => { setTimeout(() => {
console.log("onShow") console.log("onShow")
@ -380,16 +368,18 @@
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;
} }
}, },
@ -403,8 +393,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: {
// 获取客服和教练信息 // 获取客服和教练信息
@ -509,9 +499,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;
//时间间隔处理 //时间间隔处理
@ -575,39 +565,30 @@
]; ];
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){
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;
} }
}); catch(err){
return ret; console.log(err);
},
ifadd(id){
var ret=true;
this.unshiftmsg.forEach((cell)=>{
if(cell.id==id){
ret=false;
} }
});
return ret;
}, },
// 定时心跳包 // 定时心跳包
startHeartbeat() { startHeartbeat() {
@ -645,8 +626,6 @@
}, },
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连接失败')
@ -687,30 +666,19 @@
// 群聊 // 群聊
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,"加载中标记" // 消息类型 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){ 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.getMsgSender(data)
// 已读操作
this.readed();
} }
else{ else{
// 10, "撤回" 11, "已读 " 12, "消息已读回执 " 30,"加载中标记" // 10, "撤回" 11, "已读 " 12, "消息已读回执 " 30,"加载中标记"
} }
} }
// 10, "撤回" 11, "已读 " 12, "消息已读回执 " 30,"加载中标记"
if(data.type==12){
// 已读操作
this.updateRead(data);
}
} }
} }
}
} }
}); });
uni.onSocketClose(res => { uni.onSocketClose(res => {
@ -774,8 +742,6 @@
// 缓存聊天 // 缓存聊天
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={
@ -798,27 +764,6 @@
// 已读操作 // 已读操作
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;
@ -867,18 +812,13 @@
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 getReadedId() { async readUp(ii) {
const {data: res} = await uni.$http.get('/api/message/group/maxReadedId',{groupId:this.info.groupId}); const {data: res} = await uni.$http.put('/api/message/group/readed?groupId='+this.info.groupId);
if(res.data){ this.getList(ii);
this.info.minId=res.data;
this.$forceUpdate();
this.getList();
}
}, },
// 加载对话 // 加载对话
async getList() { async getList(ii) {
// if(this.ifpull()){
var that=this; var that=this;
const {data: res} = await uni.$http.get('/api/message/group/pullOfflineMessage',{minId: this.info.minId}); const {data: res} = await uni.$http.get('/api/message/group/pullOfflineMessage',{minId: this.info.minId});
this.triggered = false; this.triggered = false;
@ -886,7 +826,6 @@
const gotonum=res.data.length; const gotonum=res.data.length;
var type=0; var type=0;
res.data.forEach((cell,i)=>{ res.data.forEach((cell,i)=>{
if(this.ifadd(cell.id)){
type=cell.type; type=cell.type;
cell["ifaudio"]=false; cell["ifaudio"]=false;
//时间间隔处理 //时间间隔处理
@ -923,22 +862,23 @@
"atUserIds": data.atUserIds, "atUserIds": data.atUserIds,
}; };
this.unshiftmsg.unshift(mdata); this.unshiftmsg.unshift(mdata);
}
}); });
// // 跳转到加载数据的第一条 与前面的:id进行对照 if(ii==2){
// setTimeout(() => { // 跳转到加载数据的第一条 与前面的:id进行对照
// that.screendo(gotonum -1); setTimeout(() => {
// }, 100); 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={
@ -958,11 +898,7 @@
}; };
this.updateChatList(chatlastinfo); this.updateChatList(chatlastinfo);
// 已读操作
this.readed();
} }
// }
}, },
screendo(scrindex){ screendo(scrindex){
this.scrollToView = ''; this.scrollToView = '';
@ -986,7 +922,7 @@
// 自定义下拉刷新被触发 // 自定义下拉刷新被触发
onRefresh(event){ onRefresh(event){
// 加载聊天记录 // 加载聊天记录
this.getList(); this.readUp(2);
}, },
// 自定义下拉刷新被复位 // 自定义下拉刷新被复位
onRestore() { onRestore() {
@ -1304,9 +1240,6 @@
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,
@ -1369,21 +1302,6 @@
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;
@ -1468,15 +1386,11 @@
} }
.message { .message {
flex: none; flex: none;
max-width: 540rpx; max-width: 480rpx;
display: flex;
flex-direction: row;
} }
.messagevideo { .messagevideo {
max-width: 540rpx; max-width: 480rpx;
height: 300rpx; height: 300rpx;
display: flex;
flex-direction: row;
} }
.msg-text { .msg-text {
font-size: 32rpx; font-size: 32rpx;
@ -1723,23 +1637,6 @@
.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,13 +781,6 @@
.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;

281
pages/message/group.vue
Unescape View File

@ -12,8 +12,7 @@
<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="info.id" style="min-width: 600rpx;" <u-swipe-action ref="swipeRef" :options="options" v-for="(info, index) in grouplist" :key="index" @click="$u.throttle(actionClick(info,index), 2000)" >
@click="$u.throttle(actionClick(info,index), 2000)">
<view class="lcon" @click="gotoGroup(info,index)" :key="index" @longpress="handleLongPress(info,index)"> <view class="lcon" @click="gotoGroup(info,index)" :key="index" @longpress="handleLongPress(info,index)">
<view class="limg"> <view class="limg">
<image class="img" :src="info.img" mode="aspectFill"></image> <image class="img" :src="info.img" mode="aspectFill"></image>
@ -72,7 +71,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,
@ -83,6 +82,8 @@
} }
}, },
onLoad(options) { onLoad(options) {
// socket接收信息初始化
// this.socketinit();
}, },
onShow(){ onShow(){
this.openId = myCache('openId'); this.openId = myCache('openId');
@ -109,18 +110,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');
@ -129,7 +130,22 @@
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) {
@ -142,7 +158,6 @@
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();
@ -170,6 +185,8 @@
// ws接收消息 // ws接收消息
socketinit(){ socketinit(){
var that = this; var that = this;
// if (!that.isConnected) {
that.socketTask=uni.connectSocket({ that.socketTask=uni.connectSocket({
url: "wss://www.sanduolantoyoga.com/yoga-imserver/", url: "wss://www.sanduolantoyoga.com/yoga-imserver/",
header: { header: {
@ -190,7 +207,7 @@
uni.onSocketOpen(resopen => { uni.onSocketOpen(resopen => {
console.log('WebSocket连接已打开！'); console.log('WebSocket连接已打开！');
that.isConnected = true; that.isConnected = true;
that.$forceUpdate(); that.$forceUpdate()
uni.sendSocketMessage({ uni.sendSocketMessage({
data: JSON.stringify({ data: JSON.stringify({
"cmd": 0,//心跳 "cmd": 0,//心跳
@ -208,49 +225,8 @@
} }
}); });
// 定时发送心跳包 // 发送心跳包
this.startHeartbeat(); this.startHeartbeat();
// 拉取离线消息
this.grouplist.forEach((cell,i)=>{
if(cell.minId){
// 通过某个会话中已读消息的最大id 获取离线消息
this.pullMessage(i,cell);
}
});
// 已经删除的有最大id的继续拉取是否有消息
var data= myCache("privateMsgMaxId")?myCache("privateMsgMaxId"):[{id:0,minId:0}];
data.forEach((cell)=>{
console.log("privateMsgMaxId")
var ifcz=false;
this.grouplist.forEach((item)=>{
if(cell.id==item.id){
// 已经存在列表了，不用拉取离线信息
ifcz=true;
}
});
if(!ifcz){
// 拉取离线信息
this.getList(cell);
}
});
var data= myCache("groupMsgMaxId")?myCache("groupMsgMaxId"):[{id:0,minId:0}];
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 => { uni.onSocketMessage(res => {
@ -270,19 +246,19 @@
data.content=decodeURIComponent(data.content); 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){ 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; var ifexist=0,idx=null;
that.grouplist.forEach((cell,index)=>{ that.grouplist.forEach((cell,index)=>{
if(cell.fromuser==data.sendId&&cell.userid==data.recvId&&cell.sort=="privatechat"){ if(cell.fromuser==data.sendId&&cell.userid==data.recvId&&cell.sort=="privatechat"){
ifexist=1; ifexist=1;
idx=index;
that.grouplist[index].sl=(that.grouplist[index].sl?that.grouplist[index].sl+1:1); that.grouplist[index].sl=(that.grouplist[index].sl?that.grouplist[index].sl+1:1);
that.grouplist[index].content=data.content; that.grouplist[index].content=data.content;
that.grouplist[index].datetime=data.sendTime; that.grouplist[index].datetime=data.sendTime;
that.grouplist[index].type=data.type; that.grouplist[index].type=data.type;
that.$forceUpdate(); that.$forceUpdate();
chatinfo= JSON.parse(JSON.stringify(that.grouplist[index])) ;
console.log(chatinfo)
} }
}); });
if(ifexist==0){ if(ifexist==0){
// 未保存缓存 // 未保存缓存
// 接收到socket后更新聊天列表记录 // 接收到socket后更新聊天列表记录
@ -299,15 +275,14 @@
img: "", img: "",
sort:"privatechat" sort:"privatechat"
}; };
that.updateChatList(chatlastinfo); that.updateChatList(chatlastinfo,ifexist);
} }
else{ else{
that.updateChatList(chatinfo); that.updateChatList(that.grouplist[idx],ifexist);
} }
} }
else{ else{
// 10, "撤回" 11, "已读 " 12, "消息已读回执 " 30,"加载中标记" // 10, "撤回" 11, "已读 " 12, "消息已读回执 " 30,"加载中标记"
} }
} }
} }
@ -357,15 +332,14 @@
sendNickName: data.sendNickName, sendNickName: data.sendNickName,
sort:"groupchat" sort:"groupchat"
}; };
that.getGroupInfo(chatlastinfo); that.getGroupInfo(chatlastinfo,ifexist);
} }
else{ else{
that.getGroupInfo(that.grouplist[idx]); that.getGroupInfo(that.grouplist[idx],ifexist);
} }
} }
else{ else{
// 10, "撤回" 11, "已读 " 12, "消息已读回执 " 30,"加载中标记" // 10, "撤回" 11, "已读 " 12, "消息已读回执 " 30,"加载中标记"
} }
} }
} }
@ -386,6 +360,7 @@
that.$forceUpdate(); that.$forceUpdate();
clearInterval(that.heartbeatInterval); // 停止心跳包发送 clearInterval(that.heartbeatInterval); // 停止心跳包发送
}); });
// }
}, },
// 关闭WebSocket连接 // 关闭WebSocket连接
closeWebSocket() { closeWebSocket() {
@ -393,16 +368,6 @@
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`
@ -475,10 +440,21 @@
// 获取群聊列表 // 获取群聊列表
async getgroupsmembers(){ async getgroupsmembers(){
// 获取聊天群列表 // 获取聊天群列表
this.grouplist=myCache("chatlist-"+this.userid)?myCache("chatlist-"+this.userid):[]; this.grouplist=[];
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();
@ -493,96 +469,20 @@
this.grouplist.sort((a, b) => b.datetime - a.datetime); this.grouplist.sort((a, b) => b.datetime - a.datetime);
this.$forceUpdate(); this.$forceUpdate();
}, },
// 拉取离线信息 // 已读推送
async pullMessage(i,item) { async readUp(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 是不是列表中已经存在了，是不再拉取，不是继续拉取
// if(this.ifgroupMsgMaxId(item)){
// 群聊 // 群聊
const {data: res} = await uni.$http.get("/api/message/group/pullOfflineMessage",{minId:item.minId}); const {data: res} = await uni.$http.get("/api/message/group/pullOfflineMessage",{minId:item.minId});
if(res.data&&res.data.length>0){ if(res.data&&res.data.length>0){
@ -604,11 +504,8 @@
myCache("chatlist-"+this.userid,this.grouplist); myCache("chatlist-"+this.userid,this.grouplist);
} }
} }
// }
} }
else{ else{
// 判断当前 minId 是不是列表中已经存在了，是不再拉取，不是继续拉取
// if(this.ifprivateMsgMaxId(item)){
// 私聊 // 私聊
const {data: res} = await uni.$http.get("/api/message/private/pullOfflineMessage",{minId:item.minId}); const {data: res} = await uni.$http.get("/api/message/private/pullOfflineMessage",{minId:item.minId});
if(res.data&&res.data.length>0){ if(res.data&&res.data.length>0){
@ -630,11 +527,10 @@
myCache("chatlist-"+this.userid,this.grouplist); myCache("chatlist-"+this.userid,this.grouplist);
} }
} }
// }
} }
}, },
// 获取群信息 // 获取群信息
async getGroupInfo(info) { async getGroupInfo(info,ifexist) {
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;
@ -649,34 +545,26 @@
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); this.updateChatGroupList(info,ifexist);
} }
}, },
async updateChatGroupList(info){ async updateChatGroupList(info,ifexist){
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");
var idx=this.ifadd(info.id); if(ifexist==0){
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(!msgchat){ if(ifexist==0||!msgchat){
// 第一条聊天记录保存缓存 // 第一条聊天记录保存缓存
let firstmsg = [{ let firstmsg = [{
"fromname": name, // 发送人 "fromname": name, // 发送人
@ -722,23 +610,15 @@
else{ else{
name="匿名"; name="匿名";
img="../../static/image/girl.png"; img="../../static/image/girl.png";
var idx=this.ifadd(info.id); if(ifexist==0){
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(!msgchat){ if(ifexist==0||!msgchat){
// 第一条聊天记录保存缓存 // 第一条聊天记录保存缓存
let firstmsg = [{ let firstmsg = [{
"fromname": name, // 发送人 "fromname": name, // 发送人
@ -781,31 +661,22 @@
} }
} }
}, },
async updateChatList(info){ async updateChatList(info,ifexist){
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");
var idx=this.ifadd(info.id); if(ifexist==0){
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(!msgchat){ if(ifexist==0||!msgchat){
// 第一条聊天记录保存缓存 // 第一条聊天记录保存缓存
let firstmsg = [{ let firstmsg = [{
"fromname": info.name, // 发送人 "fromname": info.name, // 发送人
@ -852,26 +723,15 @@
else{ else{
info.name="匿名"; info.name="匿名";
info.img="../../static/image/girl.png"; info.img="../../static/image/girl.png";
var idx=this.ifadd(info.id); if(ifexist==0){
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);
console.log(info.id,msgchat); if(ifexist==0||!msgchat){
if(!msgchat){
// 第一条聊天记录保存缓存 // 第一条聊天记录保存缓存
let firstmsg = [{ let firstmsg = [{
"fromname": info.name, // 发送人 "fromname": info.name, // 发送人
@ -1020,7 +880,6 @@
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;
@ -1080,12 +939,6 @@
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,6 +360,11 @@
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

Before

Width:  |  Height:  |  Size: 1.7 KiB

Write Preview
Loading…
Cancel
Save