消息提示
This commit is contained in:
@@ -367,23 +367,23 @@ IMService.prototype.initialIMListeners = function () {
|
||||
this.onNewPrivateMessageReceive(friendId, message);
|
||||
});
|
||||
|
||||
//监听群聊消息
|
||||
this.im.on(GoEasyIM.EVENT.GROUP_MESSAGE_RECEIVED, (message) => {
|
||||
let groupId = message.groupId;
|
||||
//群未读消息+1
|
||||
let group = this.groups[groupId];
|
||||
group.unReadMessage++;
|
||||
removeGroupPendingMessage(this, groupId, message);
|
||||
//如果页面传入了相应的listener,执行listener
|
||||
this.onGroupListChange(this.groups);
|
||||
// //监听群聊消息
|
||||
// this.im.on(GoEasyIM.EVENT.GROUP_MESSAGE_RECEIVED, (message) => {
|
||||
// let groupId = message.groupId;
|
||||
// //群未读消息+1
|
||||
// let group = this.groups[groupId];
|
||||
// group.unReadMessage++;
|
||||
// removeGroupPendingMessage(this, groupId, message);
|
||||
// //如果页面传入了相应的listener,执行listener
|
||||
// this.onGroupListChange(this.groups);
|
||||
|
||||
//更新群聊消息记录
|
||||
let groupMessages = this.getGroupMessages(groupId);
|
||||
let sentMessages = groupMessages.sentMessages;
|
||||
sentMessages.push(message);
|
||||
//如果页面传入了相应的listener,执行listener
|
||||
this.onNewGroupMessageReceive(groupId, message);
|
||||
})
|
||||
// //更新群聊消息记录
|
||||
// let groupMessages = this.getGroupMessages(groupId);
|
||||
// let sentMessages = groupMessages.sentMessages;
|
||||
// sentMessages.push(message);
|
||||
// //如果页面传入了相应的listener,执行listener
|
||||
// this.onNewGroupMessageReceive(groupId, message);
|
||||
// })
|
||||
};
|
||||
|
||||
|
||||
@@ -620,6 +620,7 @@ function removeGroupPendingMessage(imService,groupId, message){
|
||||
|
||||
|
||||
|
||||
|
||||
//下面是合并的
|
||||
|
||||
|
||||
@@ -784,12 +785,8 @@ IMService.prototype.subscribePresence = function (roomId) {
|
||||
//订阅聊天室消息
|
||||
IMService.prototype.subscribeRoomMessage = function (room, user) {
|
||||
this.room = new Room(room.id, room.name, user);
|
||||
this.room.onlineUsers = {
|
||||
count: 0,
|
||||
users: []
|
||||
};
|
||||
|
||||
|
||||
this.room.messages = [];
|
||||
//监听上下线提醒
|
||||
this.listenerGroupPresence();
|
||||
|
||||
@@ -799,11 +796,11 @@ IMService.prototype.subscribeRoomMessage = function (room, user) {
|
||||
this.subscribePresence(this.room.id);
|
||||
//订阅聊天室消息
|
||||
// this.subscribeRoomMessage(this.room.id);
|
||||
this.im.subscribeGroup(this.room.id)
|
||||
this.im.subscribeGroup([this.room.id])
|
||||
.then(result => {
|
||||
console.log('消息订阅成功')
|
||||
}).catch(e => {
|
||||
console.log(e)
|
||||
console.log(e,'失败')
|
||||
})
|
||||
}
|
||||
|
||||
@@ -844,4 +841,5 @@ IMService.prototype.quitRoom = function (roomId) {
|
||||
this.im.disconnect()
|
||||
};
|
||||
|
||||
|
||||
export default IMService;
|
||||
Reference in New Issue
Block a user