import { defineStore } from "pinia";
import { computed, ref } from "vue";
import type { Cs } from "../types";
import dayjs from "dayjs";
import { service } from "/@/cool";
import { isEmpty, last } from "lodash-es";
import { useSession } from "./session";
import { uuid } from "/@/cool/utils";
import { useTools } from "./tools";
import { dateFormatter } from "../utils";
import { useBase } from "/$/base";

export const useMessage = defineStore("cs.message", () => {
	const session = useSession();
	const tools = useTools();
	const { user } = useBase();

	// 加载中
	const loading = ref(false);

	// 未读消息数
	const unread = ref(0);

	// 所有页
	const data = ref<{ id: string; data: Cs.Msg[] }[]>([]);

	// 列表
	const list = computed(() => {
		data.value.forEach((e) => {
			if (e.data[0]) {
				let date = e.data[0].createTime;

				if (date) {
					e.data.forEach((a, i) => {
						const d = dateFormatter(a.createTime);

						if (i == 0) {
							a.date = d;
						}

						if (dayjs(a.createTime).subtract(10, "minute").isAfter(dayjs(date))) {
							a.date = d;
							date = a.createTime;
						}
					});
				}
			}
		});

		return data.value;
	});

	// 追加消息
	function append(item: Cs.Msg) {
		const list = last(data.value)?.data;

		if (list) {
			list.push({
				sessionId: session.info?.id,
				type: 1,
				nickName: user.info?.name,
				avatarUrl: user.info?.headImg,
				...item
			});

			tools.scrollToBottom();
		}
	}

	// 获取消息
	async function refresh(params?: any) {
		loading.value = true;

		if (params.page == 1) {
			data.value = [];
		}

		await service.cs.msg
			.page({
				sessionId: session.info?.id,
				order: "createTime",
				sort: "desc",
				...params
			})
			.then((res) => {
				if (isEmpty(data.value) || !isEmpty(res.list)) {
					res.list.forEach((e) => {
						if (e.type == 1) {
							e.avatarUrl = e.adminUserHeadImg;
							e.nickName = e.adminUserName;
						}
					});

					data.value.unshift({
						id: uuid(),
						data: res.list.reverse() as any[]
					});
				}
			});

		loading.value = false;
	}

	// 获取未读消息
	function getUnread() {
		service.cs.msg.unreadCount().then((res) => {
			unread.value = res;
		});
	}

	// 读消息
	function read(id: number) {
		service.cs.msg.read({
			msgIds: [id]
		});
	}

	return {
		data,
		list,
		loading,
		unread,
		append,
		refresh,
		read,
		getUnread
	};
});