refactor(web-antd): 1
This commit is contained in:
@@ -63,8 +63,6 @@ export const useNotifyStore = defineStore(
|
|||||||
|
|
||||||
watch(data, (message) => {
|
watch(data, (message) => {
|
||||||
if (!message) return
|
if (!message) return
|
||||||
console.log(`接收到消息: ${message}`)
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// 尝试解析JSON
|
// 尝试解析JSON
|
||||||
const obj = JSON.parse(message)
|
const obj = JSON.parse(message)
|
||||||
|
@@ -19,18 +19,15 @@ onMounted(() => {
|
|||||||
() => notifyStore.sseList,
|
() => notifyStore.sseList,
|
||||||
(val) => {
|
(val) => {
|
||||||
const latestMessage = val[val.length - 1];
|
const latestMessage = val[val.length - 1];
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// 尝试解析消息内容
|
// 尝试解析消息内容
|
||||||
const parsedMessage = JSON.parse(latestMessage);
|
const parsedMessage = JSON.parse(latestMessage);
|
||||||
console.log('收到sse消息:', parsedMessage);
|
|
||||||
if (parsedMessage.type === 'meter') {
|
if (parsedMessage.type === 'meter') {
|
||||||
// 根据消息内容执行相应操作
|
// 根据消息内容执行相应操作
|
||||||
handleSSEMessage(parsedMessage);
|
handleSSEMessage(parsedMessage);
|
||||||
}
|
}
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
console.log('收到非JSON消息:', latestMessage);
|
console.log('收到非JSON消息:', latestMessage);
|
||||||
// 处理非JSON格式消息
|
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
{ deep: true },
|
{ deep: true },
|
||||||
|
Reference in New Issue
Block a user