wip: 🚧 通知公告临时提交

通知公告临时提交
This commit is contained in:
胡少翔
2024-09-05 17:10:29 +08:00
parent 59db084bf1
commit 35a419ff8b
4 changed files with 151 additions and 126 deletions

View File

@@ -0,0 +1,138 @@
<template>
<el-dropdown class="message nav-action-item" trigger="click">
<el-badge is-dot>
<div class="flex-center h100% p10px">
<i-ep-bell />
</div>
</el-badge>
<template #dropdown>
<div class="px-5 py-2">
<el-tabs v-model="activeTab">
<el-tab-pane
v-for="(label, key) in MessageTypeLabels"
:label="label"
:name="key"
:key="key"
>
<div
class="w-[380px] py-2"
v-for="message in getFilteredMessages(key)"
:key="message.id"
>
<el-link type="primary">
<el-text class="w-350px" size="default" truncated>
{{ message.title }}
</el-text>
</el-link>
</div>
</el-tab-pane>
</el-tabs>
<el-divider />
<div class="flex-x-between">
<el-link type="primary" :underline="false">
<span class="text-xs">查看更多</span>
<el-icon class="text-xs">
<ArrowRight />
</el-icon>
</el-link>
<el-link type="primary" :underline="false">
<span class="text-xs">全部已读</span>
</el-link>
</div>
</div>
</template>
</el-dropdown>
</template>
<script setup lang="ts">
import { Client } from "@stomp/stompjs";
import { TOKEN_KEY } from "@/enums/CacheEnum";
import { MessageTypeEnum, MessageTypeLabels } from "@/enums/MessageTypeEnum";
import NoticeAPI from "@/api/notice";
const activeTab = ref(MessageTypeEnum.MESSAGE);
const messages = ref([
{
id: 1,
title: "系统升级通知服务器将于今晚12点进行升级维护请提前保存工作内容。",
type: MessageTypeEnum.MESSAGE,
},
{
id: 2,
title: "新功能发布:我们的应用程序现在支持多语言功能。",
type: MessageTypeEnum.MESSAGE,
},
{
id: 3,
title: "重要提醒:请定期更改您的密码以保证账户安全。",
type: MessageTypeEnum.MESSAGE,
},
// {
// id: 4,
// title: "通知:您有一条未读的系统消息,请及时查看。",
// type: MessageTypeEnum.NOTICE,
// },
// {
// id: 5,
// title: "新订单通知:您有一笔新的订单需要处理。",
// type: MessageTypeEnum.NOTICE,
// },
// {
// id: 6,
// title: "审核提醒:您的审核请求已被批准。",
// type: MessageTypeEnum.NOTICE,
// },
// { id: 7, title: "待办事项:完成用户权限设置。", type: MessageTypeEnum.TODO },
// { id: 8, title: "待办事项:更新产品列表。", type: MessageTypeEnum.TODO },
// { id: 9, title: "待办事项:备份数据库。", type: MessageTypeEnum.TODO },
]);
const getFilteredMessages = (type: MessageTypeEnum) => {
return messages.value.filter((message) => message.type === type);
};
const isConnected = ref(false);
const socketEndpoint = ref(import.meta.env.VITE_APP_WS_ENDPOINT);
let stompClient: Client;
function connectWebSocket() {
console.log("连接消息ws的url" + socketEndpoint.value);
stompClient = new Client({
brokerURL: socketEndpoint.value,
connectHeaders: {
Authorization: localStorage.getItem(TOKEN_KEY) || "",
},
debug: (str) => {
console.log(str);
},
onConnect: () => {
console.log("消息ws连接成功");
isConnected.value = true;
stompClient.subscribe("/user/queue/message", (res) => {
console.log("收到消息:" + res.body);
});
},
onStompError: (frame) => {
console.error("Broker reported error: " + frame.headers["message"]);
console.error("Additional details: " + frame.body);
},
onDisconnect: () => {
isConnected.value = false;
},
});
stompClient.activate();
}
function listNotice() {
NoticeAPI.listNotice().then((res) => {
console.log(res);
});
}
onMounted(() => {
listNotice();
connectWebSocket();
});
</script>