Merge pull request 'fix : 修复工作流流程新增bug' (#25) from dj into master
Reviewed-on: http://git.feashow.cn/clay/mosr-web/pulls/25
This commit is contained in:
@@ -73,56 +73,56 @@ const handleViewDetails = (noticeId) => {
|
||||
viewForm.value = res.data
|
||||
})
|
||||
}
|
||||
const setWsUrl=(url)=>{
|
||||
return (window.location.protocol === 'http:' ? "ws://" : "wss://")+window.location.host + import.meta.env.VITE_BASE_URL + url;
|
||||
}
|
||||
const initWebSocket = () => {
|
||||
try {
|
||||
//怎么区分http https /url(全局url) 封装url 只填个url?
|
||||
const wsUrl=setWsUrl('/notice-ws/notice')
|
||||
const socket = new WebSocket(wsUrl)
|
||||
// 2. ws.send()给服务器发送信息
|
||||
//连接发生错误的回调方法
|
||||
socket.onerror = function () {
|
||||
console.log("ws连接发生错误");
|
||||
};
|
||||
//连接成功建立的回调方法
|
||||
socket.onopen = function () {
|
||||
let authInfo = {
|
||||
token: getToken(),
|
||||
type: "auth",
|
||||
cluster: "notice"
|
||||
}
|
||||
socket.send(JSON.stringify(authInfo))
|
||||
console.log("ws连接成功");
|
||||
}
|
||||
//接收到消息的回调方法
|
||||
socket.onmessage = function (event) {
|
||||
let data = JSON.parse(event.data)
|
||||
console.log('测试铃铛',data)
|
||||
if (data.type === 'notice') {
|
||||
noticeList.value.push(data.notice)
|
||||
total.value += 1
|
||||
} else if(!data.type&&data.cluster==="notice"){
|
||||
noticeList.value.push(data)
|
||||
total.value += 1
|
||||
}
|
||||
// console.log("服务器返回的信息: ", JSON.parse(event.data));
|
||||
}
|
||||
//连接关闭的回调方法
|
||||
socket.onclose = function () {
|
||||
// initWebSocket()
|
||||
console.log("ws连接关闭");
|
||||
}
|
||||
setInterval(() => {
|
||||
socket.send(JSON.stringify(send))
|
||||
}, 30000)
|
||||
} catch (e) {
|
||||
console.log(e)
|
||||
console.log("ws连接失败");
|
||||
}
|
||||
}
|
||||
initWebSocket()
|
||||
// const setWsUrl=(url)=>{
|
||||
// return (window.location.protocol === 'http:' ? "ws://" : "wss://")+window.location.host + import.meta.env.VITE_BASE_URL + url;
|
||||
// }
|
||||
// const initWebSocket = () => {
|
||||
// try {
|
||||
// //怎么区分http https /url(全局url) 封装url 只填个url?
|
||||
// const wsUrl=setWsUrl('/notice-ws/notice')
|
||||
// const socket = new WebSocket(wsUrl)
|
||||
// // 2. ws.send()给服务器发送信息
|
||||
// //连接发生错误的回调方法
|
||||
// socket.onerror = function () {
|
||||
// console.log("ws连接发生错误");
|
||||
// };
|
||||
// //连接成功建立的回调方法
|
||||
// socket.onopen = function () {
|
||||
// let authInfo = {
|
||||
// token: getToken(),
|
||||
// type: "auth",
|
||||
// cluster: "notice"
|
||||
// }
|
||||
// socket.send(JSON.stringify(authInfo))
|
||||
// console.log("ws连接成功");
|
||||
// }
|
||||
// //接收到消息的回调方法
|
||||
// socket.onmessage = function (event) {
|
||||
// let data = JSON.parse(event.data)
|
||||
// console.log('测试铃铛',data)
|
||||
// if (data.type === 'notice') {
|
||||
// noticeList.value.push(data.notice)
|
||||
// total.value += 1
|
||||
// } else if(!data.type&&data.cluster==="notice"){
|
||||
// noticeList.value.push(data)
|
||||
// total.value += 1
|
||||
// }
|
||||
// // console.log("服务器返回的信息: ", JSON.parse(event.data));
|
||||
// }
|
||||
// //连接关闭的回调方法
|
||||
// socket.onclose = function () {
|
||||
// // initWebSocket()
|
||||
// console.log("ws连接关闭");
|
||||
// }
|
||||
// setInterval(() => {
|
||||
// socket.send(JSON.stringify(send))
|
||||
// }, 30000)
|
||||
// } catch (e) {
|
||||
// console.log(e)
|
||||
// console.log("ws连接失败");
|
||||
// }
|
||||
// }
|
||||
// initWebSocket()
|
||||
|
||||
const searchNotifyList = () => {
|
||||
let params = {
|
||||
|
||||
Reference in New Issue
Block a user