apply-assistant-v3/root/NEUIKit/pages/Chat/index.vue

<template>
	<!-- 处理滚动穿透  此为官方推荐做法 https://uniapp.dcloud.net.cn/component/uniui/uni-popup.html#%E4%BB%8B%E7%BB%8D -->
	<page-meta :page-style="'overflow:' + (moveThrough ? 'hidden' : 'visible')"></page-meta>
	<div :class="isH5 ? 'msg-page-wrapper-h5' : 'msg-page-wrapper'">
		<NavBar :title="title" :showLeft="true" v-if="false">
			<template v-slot:left>
				<div @click="backToConversation">
					<Icon type="icon-zuojiantou" :size="22"></Icon>
				</div>
			</template>
		</NavBar>
		<div class="msg-alert">
			<NetworkAlert />
		</div>
		<div :class="isH5 ? 'msg-wrapper-h5' : 'msg-wrapper'">
			<MessageList :conversationType="conversationType" :to="to" :msgs="msgs" :loading-more="loadingMore" :no-more="noMore" :reply-msgs-map="replyMsgsMap" />
		</div>
		<!-- <div style="height: 'auto';position: fixed;left: 0;bottom: 0;width: 100vw;"> -->
		<MessageInput
			:reply-msgs-map="replyMsgsMap"
			:jobListShow="jobListShow"
			@jobListShow="
				(e) => {
					jobListShow = e;
				}
			"
			:conversation-type="conversationType"
			:to="to"
		/>
		<!-- </div> -->

		<u-popup v-model="jobListShow" mode="bottom" z-index="999999" border-radius="12" :closeable="false" :mask-close-able="true" :mask="true" @close="jobListShow = false">
			<scroll-view :scroll-y="true" @scrolltolower="reachBottom" class="g_bg_ed" style="height: 90vh">
				<div class="">
					<div class="m-search g_p_10 g_pt_8 g_position_rela g_flex_1 g_bg_ed sticky" style id="searchInputBox">
						<u-search height="80" v-model="keyword" @input="checkLength" @clear="searchJob" @search="searchJob" class="" placeholder="搜索职位名称" bg-color="#fff" :show-action="false" placeholder-class="g_c_c" search-icon-color="#999999" :maxlength="20"></u-search>
					</div>
					<g-list-job from="chat" @uploadList="getList" @sendJob="sendJob" bg="#ededed" class="" :query="query" :list="query.list" :loading="loading" :speed="speed" :isShowLoginBtn="false" emptyText="嘿，这里还没有数据呢" />
				</div>
			</scroll-view>
		</u-popup>
	</div>
</template>

<script lang="ts" setup>
import gListJob from "../../../../components/list/job";
import { onShow } from "@dcloudio/uni-app";
import { events } from "../../utils/constants";
import { trackInit } from "../../utils/reporter";
import { autorun } from "mobx";
import { ref, onMounted, computed, onUnmounted, getCurrentInstance } from "vue";
// import { ref, onMounted, onUnmounted, getCurrentInstance } from "../../utils/transformVue";
import { deepClone, getUniPlatform } from "../../utils";
import { onLoad, onUnload } from "@dcloudio/uni-app";
import { customSwitchTab, customNavigateTo } from "../../utils/customNavigate";
import NetworkAlert from "../../components/NetworkAlert.vue";
import NavBar from "./message/nav-bar.vue";
import Icon from "../../components/Icon.vue";
import MessageList from "./message/message-list.vue";
import MessageInput from "./message/message-input.vue";
import { HISTORY_LIMIT, MSG_ID_FLAG } from "../../utils/constants";
import { t } from "../../utils/i18n";
import { V2NIMMessage } from "nim-web-sdk-ng/dist/v2/NIM_UNIAPP_SDK/V2NIMMessageService";
import { V2NIMConst } from "nim-web-sdk-ng/dist/v2/NIM_UNIAPP_SDK";
const G = getCurrentInstance().appContext.app.config.globalProperties.G;
const F = getCurrentInstance().appContext.app.config.globalProperties.F;
const api = getCurrentInstance().appContext.app.config.globalProperties.api;
export interface YxReplyMsg {
	messageClientId: string;
	scene: V2NIMConst.V2NIMConversationType;
	from: string;
	receiverId: string;
	to: string;
	idServer: string;
	time: number;
}

trackInit("ChatUIKit");

const title = ref("");
const jobListShow = ref(false);
const toDetail = () => {
	uni.navigateTo({
		url: "/root/detail/job?id=" + 146579,
	});
};
const conversationId = uni.$UIKitStore.uiStore.selectedConversation;
const conversationType = uni.$UIKitNIM.V2NIMConversationIdUtil.parseConversationType(conversationId);
const to = uni.$UIKitNIM.V2NIMConversationIdUtil.parseConversationTargetId(conversationId);

const isH5 = getUniPlatform() === "web";

// 处理uni-popup 引起的滚动穿透
const moveThrough = ref(false);

const backToConversation = () => {
	customSwitchTab({
		url: "/pages/Conversation/index",
	});
};

// 是否需要显示群组消息已读未读，默认 false
const teamManagerVisible = uni.$UIKitStore.localOptions.teamMsgReceiptVisible;
// 是否需要显示 p2p 消息、p2p会话列表消息已读未读，默认 false
const p2pMsgReceiptVisible = uni.$UIKitStore.localOptions.p2pMsgReceiptVisible;

let isMounted = false;

const loadingMore = ref(false);
const noMore = ref(false);

const msgs = ref<V2NIMMessage[]>([]);

// 回复
const replyMsgsMap = ref<Record<string, V2NIMMessage>>();

const handleDismissTeam = (data: any) => {
	if (data.teamId === to) {
		uni.showModal({
			content: t("onDismissTeamText"),
			showCancel: false,
			success(data) {
				if (data.confirm) {
					backToConversation();
				}
			},
		});
	}
};

const handleRemoveTeamMembers = (data: any) => {
	uni
		.showToast({
			title: t("onRemoveTeamText"),
			icon: "success",
			duration: 1000,
		})
		.then(() => {
			backToConversation();
		});
};

// 收到新消息
const handleReceiveMessages = (msgs: V2NIMMessage[]) => {
	const routes = getCurrentPages();
	const curRoute = routes[routes.length - 1].route;

	// 不是当前用户的其他端发送的消息且是当前会话的未读消息，才发送已读回执
	if (msgs.length && !msgs[0]?.isSelf && msgs[0].conversationId == conversationId && curRoute?.includes("Chat/index")) {
		handleMsgReceipt(msgs);
	}
	uni.$emit(events.ON_SCROLL_BOTTOM, msgs);
};

// 处理收到消息的已读回执
const handleMsgReceipt = (msg: V2NIMMessage[]) => {
	if (msg[0].conversationType === V2NIMConst.V2NIMConversationType.V2NIM_CONVERSATION_TYPE_P2P && p2pMsgReceiptVisible) {
		uni.$UIKitStore.msgStore.sendMsgReceiptActive(msg[0]);
	} else if (msg[0].conversationType === V2NIMConst.V2NIMConversationType.V2NIM_CONVERSATION_TYPE_TEAM && teamManagerVisible) {
		uni.$UIKitStore.msgStore.sendTeamMsgReceiptActive(msg);
	}
};

// 处理历史消息的已读未读
const handleHistoryMsgReceipt = (msgs: V2NIMMessage[]) => {
	// 如果是单聊
	if (conversationType === V2NIMConst.V2NIMConversationType.V2NIM_CONVERSATION_TYPE_P2P && p2pMsgReceiptVisible) {
		const myUserAccountId = uni.$UIKitNIM.V2NIMLoginService.getLoginUser();
		const othersMsgs = msgs
			.filter(
				(item: V2NIMMessage) =>
					// @ts-ignore
					!["beReCallMsg", "reCallMsg"].includes(item.recallType || "")
			)
			.filter((item: V2NIMMessage) => item.senderId !== myUserAccountId);
		// 发送单聊消息已读回执
		if (othersMsgs.length > 0) {
			uni.$UIKitStore.msgStore.sendMsgReceiptActive(othersMsgs?.[0]);
		}
		// 如果是群聊
	} else if (conversationType === V2NIMConst.V2NIMConversationType.V2NIM_CONVERSATION_TYPE_TEAM && teamManagerVisible) {
		const myUserAccountId = uni.$UIKitNIM.V2NIMLoginService.getLoginUser();
		const myMsgs = msgs
			.filter(
				(item: V2NIMMessage) =>
					// @ts-ignore
					!["beReCallMsg", "reCallMsg"].includes(item.recallType || "")
			)
			.filter((item: V2NIMMessage) => item.senderId === myUserAccountId);

		uni.$UIKitStore.msgStore.getTeamMsgReadsActive(myMsgs, conversationId);

		// 发送群消息已读回执
		// sdk 要求 一次最多传入 50 个消息对象
		const othersMsgs = msgs
			.filter(
				(item: V2NIMMessage) =>
					// @ts-ignore
					!["beReCallMsg", "reCallMsg"].includes(item.recallType || "")
			)
			.filter((item: V2NIMMessage) => item.senderId !== myUserAccountId);

		if (othersMsgs.length > 0 && othersMsgs.length < 50) {
			uni.$UIKitStore.msgStore.sendTeamMsgReceiptActive(othersMsgs);
		}
	}
};

// 拉取历史消息
const getHistory = async (endTime: number, lastMsgId?: string) => {
	try {
		if (noMore.value) {
			return [];
		}
		if (loadingMore.value) {
			return [];
		}
		loadingMore.value = true;
		if (conversationId) {
			const historyMsgs = await uni.$UIKitStore.msgStore.getHistoryMsgActive({
				conversationId,
				endTime,
				lastMsgId,
				limit: HISTORY_LIMIT,
			});

			// console.log(historyMsgs)

			// 在点击会话时，去获取并更新 pin 和 msg 信息。
			await uni.$UIKitStore.msgStore.getPinnedMessageListActive(conversationId);

			loadingMore.value = false;

			if (historyMsgs.length < HISTORY_LIMIT) {
				noMore.value = true;
			}
			// 消息已读未读相关
			handleHistoryMsgReceipt(historyMsgs);
			return historyMsgs;
		}
	} catch (error) {
		loadingMore.value = false;
		throw error;
	}
};

// 加载更多消息
const loadMoreMsgs = (lastMsg: V2NIMMessage) => {
	// console.log("已登录已登录已登录已登录已登录已登录已登录已登录已登录")
	getHistory(lastMsg.createTime, lastMsg.messageServerId).then((res: V2NIMMessage[]) => {
		// console.log(res)
		// console.log("执行一次执行一次执行一次执行一次执行一次执行一次执行一次执行一次")
		uni.$emit("newScroll");
	});
};

const conversationTypeWatch = autorun(() => {
	// 如果是单聊
	if (conversationType === V2NIMConst.V2NIMConversationType.V2NIM_CONVERSATION_TYPE_P2P) {
		title.value = deepClone(uni.$UIKitStore.uiStore.getAppellation({ account: to }));
		// 如果是群聊
	} else if (conversationType === V2NIMConst.V2NIMConversationType.V2NIM_CONVERSATION_TYPE_TEAM) {
		const team = uni.$UIKitStore.teamStore.teams.get(to);
		const subTitle = `(${team?.memberCount || 0})`;
		title.value = (team?.name || "") + subTitle;
	}
});

// 监听连接状态
const connectedWatch = autorun(() => {
	if (uni.$UIKitStore.connectStore.connectStatus === V2NIMConst.V2NIMConnectStatus.V2NIM_CONNECT_STATUS_CONNECTED) {
		if (uni.$UIKitStore.connectStore.loginStatus == V2NIMConst.V2NIMLoginStatus.V2NIM_LOGIN_STATUS_LOGINED) {
			getHistory(Date.now()).then(() => {
				if (!isMounted) {
					console.log("已登录已登录已登录已登录已登录已登录已登录已登录已登录");
					// uni.$emit(events.ON_SCROLL_BOTTOM)
					isMounted = true;
				}
			});
		}
	}
});

// 动态更新消息
const msgsWatch = autorun(() => {
	// 这里需要 Clone，否则 pinState 更新了，对应的消息展示不会重新渲染
	const messages = [...uni.$UIKitStore.msgStore.getMsg(conversationId)];
	if (messages.length !== 0) {
		msgs.value = messages;
	}

	// 遍历所有消息，找出被回复消息，储存在map中
	if (messages.length !== 0) {
		const _replyMsgsMap: any = {};
		const reqMsgs: YxReplyMsg[] = [];
		const messageClientIds: Record<string, string> = {};
		msgs.value.forEach((msg) => {
			if (msg.serverExtension) {
				try {
					// yxReplyMsg 存储着被回复消息的相关消息
					const { yxReplyMsg } = JSON.parse(msg.serverExtension);
					if (yxReplyMsg) {
						// 从消息列表中找到被回复消息，replyMsg 为被回复的消息
						const replyMsg = msgs.value.find((item) => item.messageClientId === yxReplyMsg.idClient);
						// 如果直接找到，存储在map中
						if (replyMsg) {
							_replyMsgsMap[msg.messageClientId] = replyMsg;
							// 如果没找到，说明被回复的消息可能有三种情况：1.被删除 2.被撤回 3.不在当前消息列表中（一次性没拉到，在之前的消息中）
						} else {
							_replyMsgsMap[msg.messageClientId] = { messageClientId: "noFind" };
							const { scene, from, to, idServer, messageClientId, time, receiverId } = yxReplyMsg;

							if (scene && from && to && idServer && messageClientId && time && receiverId) {
								reqMsgs.push({
									scene,
									from,
									to,
									idServer,
									messageClientId,
									time,
									receiverId,
								});
								messageClientIds[idServer] = msg.messageClientId;
							}
						}
					}
				} catch {}
			}
		});

		if (reqMsgs.length > 0) {
			// 从服务器拉取被回复消息, 但是有频率控制
			uni.$UIKitNIM.V2NIMMessageService.getMessageListByRefers(
				reqMsgs.map((item) => ({
					senderId: item.from,
					receiverId: item.receiverId,
					messageClientId: item.messageClientId,
					messageServerId: item.idServer,
					createTime: item.time,
					conversationType: item.scene,
					conversationId: item.to,
				}))
			)
				.then((res) => {
					if (res?.length > 0) {
						res.forEach((item: V2NIMMessage) => {
							if (item.messageServerId) {
								_replyMsgsMap[messageClientIds[item.messageServerId]] = item;
							}
						});
					}
					replyMsgsMap.value = { ..._replyMsgsMap };
				})
				.catch(() => {
					replyMsgsMap.value = { ..._replyMsgsMap };
				});
		} else {
			replyMsgsMap.value = { ..._replyMsgsMap };
		}
	}

	// 当聊天消息小于6条时，由于页面被键盘撑起，导致已经发出的消息不可见，所以需要隐藏键盘
	// if (messages.length < 6) {
	//   uni.hideKeyboard()
	// }
});

// 设置页面标题
const setNavTitle = () => {
	if (conversationType === V2NIMConst.V2NIMConversationType.V2NIM_CONVERSATION_TYPE_P2P) {
		title.value = uni.$UIKitStore.uiStore.getAppellation({ account: to });
	} else if (conversationType === V2NIMConst.V2NIMConversationType.V2NIM_CONVERSATION_TYPE_TEAM) {
		const team = uni.$UIKitStore.teamStore.teams.get(to);
		const subTitle = `(${team?.memberCount || 0})`;
		title.value = (team?.name || "") + subTitle;
	}
};

onShow(function () {
	setNavTitle();
	scrollToBottom();
	// 从其他页面返回到聊天页时，可能使用的是 uni.navigateBack，此时不会触发onload等事件，但此时需要将收到的新消息发送已读未读
	if (msgs.value.length) {
		const _msgs = [...msgs.value].reverse();
		handleHistoryMsgReceipt(_msgs);
	}
});

const scrollToBottom = () => {
	const timer = setTimeout(() => {
		uni.$emit(events.ON_SCROLL_BOTTOM);
		clearTimeout(timer);
	}, 300);
};

onLoad((options) => {
	uni.$on(events.HANDLE_MOVE_THROUGH, (flag) => {
		moveThrough.value = flag;
	});
  console.log("options聊天", options);
	uni.setNavigationBarTitle({
		title: options.ctitle,
	});
});
const msgHeight = ref(0);
onMounted(() => {
	setNavTitle();
	getList();
	uni.$on("msgHeight", (res) => {
		console.log(res);
		msgHeight.value = res;
	});

	// scrollToBottom()

	uni.$UIKitNIM.V2NIMMessageService.on("onReceiveMessages", handleReceiveMessages);

	uni.$UIKitNIM.V2NIMTeamService.on("onTeamDismissed", handleDismissTeam);

	uni.$UIKitNIM.V2NIMTeamService.on("onTeamLeft", handleRemoveTeamMembers);

	uni.$on(events.GET_HISTORY_MSG, loadMoreMsgs);

	
});

onUnmounted(() => {
	uni.$UIKitNIM.V2NIMTeamService.off("onTeamDismissed", handleDismissTeam);

	uni.$UIKitNIM.V2NIMTeamService.off("onTeamMemberLeft", handleRemoveTeamMembers);

	uni.$UIKitNIM.V2NIMMessageService.off("onReceiveMessages", handleReceiveMessages);

	uni.$off(events.GET_HISTORY_MSG, loadMoreMsgs);

	// 移除store的数据监听
	connectedWatch();
	msgsWatch();
	conversationTypeWatch();
});
const query = ref({
	page: 1,
	size: 50,
	list: [],
	isFinish: -1,
});
const loading = ref(false);
const speed = ref(-1);
const keyword = ref("");
const checkLength = (e) => {
	console.log("e", e);
	console.log("keyword", keyword.value);
	if (e.length == 0) {
		keyword.value = "";
		searchJob();
	}
};
const searchJob = () => {
	query.value.list = [];
	query.value.page = 1;
	getList();
};
const getList = ($type = "init") => {
	loading.value = true;
	G.Post(
		api.job_list,
		{
			pageNum: query.value.page,
			pageSize: query.value.size,
			agencyId: uni.getStorageSync("apply-agencyId"),
			classify: 99,
			sortTag: 2,
			keys: keyword.value,
			cityName: "全国",
		},
		(res) => {
			console.log("res", res);
			loading.value = false;
			speed.value = res.recordCount;
			query.value.isFinish = res.recordList.length;
			console.log("query.value", query.value);
			res.recordList = G.toGetAddressv3(res.recordList);
			res.recordList = G.toGetAge(res.recordList);
			res.recordList = G.yijobCopy(res.recordList);
			if ($type == "init") {
				query.value.list = [];
				if (res.recordList.length > 0) {
					query.value.list = res.recordList.map((item, index) => {
						// console.log(item)
						return {
							...item,
							title: item.jobName,
							address: item.district + item.age,
							priceStr: item.salaryClassify != 7 ? G.getSalaryClassifyValue(item.salaryClassify, item.salaryClassifyValue) : G.getSalaryClassifyValue(item.salaryClassify, item.minMonthlyPay, item.maxMonthlyPay),
							logo: item.agencyLogo,
							time: G.setDeadLine(item.updateTime, "jiaofu"),
							fuWuFei: G.setReturnFee(item.returnFee, item.returnFeeType),
							gender: G.getGenderByMinAge(item),
							leafCateId: item.id,
							// serverPrice: tabInfo.value.list[tabInfo.value.active].tip == 2 ? G.setReturnFee(item.returnFee, item.returnFeeType) : G.setReturnFee(item.agencyReturnFee, item.agencyReturnFeeType),
							serverPrice: G.setReturnFee(item.agencyReturnFee, item.agencyReturnFeeType),
							recruitmentSwitch: item.recruitment == 1 ? true : false,
							recruitmentImage: item.recruitment,
							isToday: item.today == 0 ? false : true,
						};
					});
				}
			} else {
				query.value.list = query.value.list.concat(
					res.recordList.map((item, index) => {
						return {
							...item,
							title: item.jobName,
							priceStr: item.salaryClassify != 7 ? G.getSalaryClassifyValue(item.salaryClassify, item.salaryClassifyValue) : G.getSalaryClassifyValue(item.salaryClassify, item.minMonthlyPay, item.maxMonthlyPay),
							fuWuFei: G.setReturnFee(item.returnFee, item.returnFeeType),
							gender: G.getGenderByMinAge(item),
							logo: item.agencyLogo,
							time: G.setDeadLine(item.updateTime, "jiaofu"),
							leafCateId: item.id,
							serverPrice: G.setReturnFee(item.agencyReturnFee, item.agencyReturnFeeType),
							recruitmentSwitch: item.recruitment == 1 ? true : false,
							recruitmentImage: item.recruitment,
							isToday: item.today == 0 ? false : true,
						};
					})
				);
			}
			console.log("query.value.list", query.value.list);
		}
	);
};
const sendMsg = () => {
	const customMsg = uni.$UIKitNIM.V2NIMMessageCreator.createCustomMessage(
		"",
		JSON.stringify({
			type: "0",
			content: "测试自定义消息",
		})
	);
	uni.$UIKitStore.msgStore.sendMessageActive({
		message: customMsg,
		conversationId,
		sendBefore: () => {
			jobListShow.value = false;
			uni.$emit(events.ON_SCROLL_BOTTOM);
		},
	});
};
const sendJob = (_item) => {
	console.log("_item", _item);
	let listInner = ["district", "gender", "age"];
	let newList = [];
	listInner.forEach((item) => {
		if (_item[item]) {
			newList.push(_item[item]);
		}
	});
	_item.info = newList.join("丨");
	const customMsg = uni.$UIKitNIM.V2NIMMessageCreator.createCustomMessage(
		"",
		JSON.stringify({
			type: 100000,
			title: _item.jobName,
			info: _item.info,
			label: _item.jobSpecialLabelNameArray.length > 0 ? _item.jobSpecialLabelNameArray : [],
			salaryClassifyValue: _item.priceStr,
			serviceFee: _item.fuWuFei ? _item.fuWuFei : "",
			monthPay: _item.monthlyPay,
			jobId: _item.id,
		})
	);
	console.log("customMsg", customMsg);
	uni.$UIKitStore.msgStore.sendMessageActive({
		msg: customMsg,
		conversationId,
		sendBefore: () => {
			jobListShow.value = false;
			uni.$emit(events.ON_SCROLL_BOTTOM);
			// scrollBottom();
		},
	});
};
const reachBottom = () => {
	if (query.value.isFinish == -1 || query.value.isFinish == query.value.size) {
		query.value.page++;
		getList("concat");
	}
};
onUnload(() => {
	uni.$off(events.CONFIRM_FORWARD_MSG);
	uni.$off(events.CANCEL_FORWARD_MSG);
});
</script>

<style lang="scss">
@import "../../base.scss";
@import "../../../../static/css/iconfont.css";
page {
	height: 100%;
	overflow: hidden;
}

.msg-page-wrapper {
	display: flex;
	flex-direction: column;
	height: 100vh;
	overflow: hidden;
	background-color: #ededed;
}

.msg-page-wrapper-h5 {
	width: 100%;
	height: 100%;
	max-width: 100%;
	overflow: hidden;
	box-sizing: border-box;
	display: flex;
	flex-direction: column;
	position: relative;
}

.msg-alert {
	display: flex;
	flex-direction: column;
	width: 100%;
	height: auto;
	z-index: 1;
}

.msg-wrapper {
	width: 100%;
	overflow: hidden;
	box-sizing: border-box;
	display: flex;
	flex-direction: column;
	position: relative;
	flex: 1;
	padding-bottom: calc(env(safe-area-inset-bottom) + 69px);
}

.msg-wrapper-h5 {
	width: 100%;
	height: 100%;
	max-width: 100%;
	overflow: hidden;
	box-sizing: border-box;
	display: flex;
	flex-direction: column;
	position: relative;
}

.msg-wrapper > message-list {
	height: 100%;
}
.sticky {
	position: sticky;
	top: 0px;
	left: 0;
	z-index: 100;
}
</style>