rtim/store/modules/conversation.js

import {
	v4 as uuidv4
} from "uuid";
import IMSDK from "openim-uniapp-polyfill";

const state = {
	conversationList: [],
	currentConversation: {},
	unReadCount: 0,
	currentGroup: {},
	currentMemberInGroup: {},
	revokeMap: {}
};

const mutations = {
	SET_CONVERSATION_LIST(state, list) {
		state.conversationList = [...list];
	},
	SET_CURRENT_CONVERSATION(state, conversation) {
		state.currentConversation = {
			...conversation,
		};
	},
	SET_UNREAD_COUNT(state, count) {
	   //console.log("qxj SET_UNREAD_COUNT",count);
	  if(count>0) {
		    if(count<100){
				uni.setTabBarBadge({index: 0,text: count+""});
			}else{
				uni.setTabBarBadge({index: 0,text: "99+"});
			}
			
		// #ifdef APP-PLUS
				if(count==1){
					 plus.runtime.setBadgeNumber(-1);
				}
				else{
					 plus.runtime.setBadgeNumber(count);
				}

		//#endif
		
	  } else {
			  uni.removeTabBarBadge({ index: 0 }); 
			// #ifdef APP-PLUS
	            const sysInfo = uni.getSystemInfoSync();
	            const brand = (sysInfo.brand || '').toLowerCase();
	            if (brand === 'vivo') {
	                plus.runtime.setBadgeNumber(-1);
	            } else {
	                plus.runtime.setBadgeNumber(0);
	            }
	           
			//#endif
			
			
	  }
	  state.unReadCount = count;
	},
	SET_CURRENT_GROUP(state, group) {
		state.currentGroup = {
			...group,
		};
	},
	SET_CURRENT_MEMBER_IN_GROUP(state, member) {
		state.currentMemberInGroup = {
			...member,
		};
	},
	SET_REVOKE_MAP(state, message) {
		state.revokeMap = {
			...state,
			[message.clientMsgID]: {
				text: getMessageText(message),
				quoteMessage: message.quoteElem?.quoteMessage,
			}
		};
	},
};

const actions = {
	async getConversationList({state,commit},isFirstPage = true) {
		try {
			let uuid=uuidv4();
			const {data} = await IMSDK.asyncApi(IMSDK.IMMethods.GetConversationListSplit,uuidv4(), {
					offset: isFirstPage ? 0 : state.conversationList.length,
					count: 200,
				}
			);
			const conversationData = data || [];
			commit("SET_CONVERSATION_LIST", [
				...(isFirstPage ? [] : state.conversationList),
				...conversationData,
			]);
			return conversationData;
		} catch (e) {
			commit("SET_CONVERSATION_LIST", []);
			return [];
		}
	},
	delConversationByCID({state,commit}, conversationID) {
		const tmpList = [...state.conversationList];
		const idx = tmpList.findIndex(
			(conversation) => conversation.conversationID === conversationID,
		);
		if (idx > -1) {
			tmpList.splice(idx, 1);
			commit("SET_CONVERSATION_LIST", tmpList);
		}
	},
	getCurrentGroup({commit}, groupID) {
		console.log("qxj getCurrentGroup groupID",groupID);
		IMSDK.asyncApi(IMSDK.IMMethods.GetSpecifiedGroupsInfo, uuidv4(), [
			groupID
		]).then(({data}) => {
			console.log("qxj getCurrentGroup data",data);
			commit("SET_CURRENT_GROUP", data[0] ?? {});
		});
	},
	getCurrentMemberInGroup({
		commit,
		rootState
	}, groupID) {
		IMSDK.asyncApi(IMSDK.IMMethods.GetSpecifiedGroupMembersInfo, uuidv4(), {
			groupID,
			userIDList: [rootState.user.selfInfo.userID],
		}).then(({
			data
		}) => {
			commit("SET_CURRENT_MEMBER_IN_GROUP", data[0] ?? {});
		});
	},
	getUnReadCount({
		commit
	}) {
		IMSDK.asyncApi(IMSDK.IMMethods.GetTotalUnreadMsgCount, uuidv4()).then((res) => {
			
			commit("SET_UNREAD_COUNT", res.data);
		}, );
	},
	updateCurrentMemberInGroup({
		commit,
		state
	}, memberInfo) {
		if (memberInfo.groupID === state.currentMemberInGroup.groupID && memberInfo.userID === state
			.currentMemberInGroup.userID) {
			commit("SET_CURRENT_MEMBER_IN_GROUP", memberInfo);
		}
	},
	resetConversationState({
		commit
	}) {
		commit("SET_CURRENT_MEMBER_IN_GROUP", {});
		commit("SET_CURRENT_GROUP", {});
		commit("SET_CURRENT_CONVERSATION", {});
	},
	addRevokedMessage({
		commit
	}, payload) {
		commit("SET_REVOKE_MAP", payload);
	}

};

const getMessageText = (message) => {
	if (message.atTextElem) {
		return message.atTextElem.text;
	}
	if (message.quoteElem) {
		return message.quoteElem.text;
	}
	return message.textElem.content;
};

export default {
	namespaced: true,
	state,
	mutations,
	actions,
};