Skip to content
项目
群组
代码片段
帮助
正在加载...
帮助
提交反馈
为 GitLab 提交贡献
登录
切换导航
P
pica-admin-consultation
项目
项目
详情
动态
版本
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
计划
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
收起侧边栏
Close sidebar
动态
分支图
统计图
创建新议题
作业
提交
议题看板
打开侧边栏
com.pica.cloud.education.frontend
pica-admin-consultation
提交
dfc19d18
提交
dfc19d18
编写于
8月 08, 2021
作者:
张磊
浏览文件
操作
浏览文件
下载
差异文件
Merge branch 'feat/zl' into 'develop'
save See merge request
!97
上级
e36a311d
2029da93
变更
1
隐藏空白字符变更
内嵌
并排
正在显示
1 个修改的文件
包含
66 行增加
和
66 行删除
+66
-66
socket.js
src/store/module/socket.js
+66
-66
未找到文件。
src/store/module/socket.js
浏览文件 @
dfc19d18
...
...
@@ -71,11 +71,11 @@ export default {
// ...
});
s
tate
.
s
ocketClient
.
on
(
"reconnect"
,
(
socket
)
=>
{
socketClient
.
on
(
"reconnect"
,
(
socket
)
=>
{
console
.
log
(
'--reconnect'
,
socket
);
// ...
});
s
tate
.
s
ocketClient
.
on
(
'reconnecting'
,
(
attemptNumber
)
=>
{
socketClient
.
on
(
'reconnecting'
,
(
attemptNumber
)
=>
{
// ...
console
.
log
(
'--reconnecting'
,
attemptNumber
);
});
...
...
@@ -87,70 +87,70 @@ export default {
state
.
socketClient
=
payload
;
},
SET_IOLISTION
:
(
state
,
payload
)
=>
{
if
(
!
state
.
socketClient
){
return
false
;
}
state
.
socketClient
.
on
(
"connect"
,
(
socket
)
=>
{
console
.
log
(
'socket 链接成功'
,
socket
,
state
.
socketClient
);
});
state
.
socketClient
.
on
(
"connect_error"
,
(
err
)
=>
{
console
.
log
(
'socket connect_error'
,
err
);
// state.socketClient.connect();
});
state
.
socketClient
.
on
(
"disconnect"
,
(
socket
)
=>
{
console
.
log
(
'socket disconnect----'
,
socket
);
// state.socketClient.connect();
});
state
.
socketClient
.
on
(
"diagnose_push_event"
,
(
socket
)
=>
{
console
.
log
(
'diagnose_push_event---'
,
socket
);
const
{
list
,
allSize
,
countRespList
}
=
socket
;
console
.
log
(
'--_VM'
,
_VM
.
$route
)
store
.
commit
(
'updateCurrentDiagList'
,
list
);
store
.
commit
(
'updateAllSize'
,
allSize
);
store
.
commit
(
'updateCurrentCalList'
,
countRespList
);
});
state
.
socketClient
.
on
(
"diagnose_call_push_event"
,
(
socket
)
=>
{
console
.
log
(
'diagnose_call_push_event---'
,
socket
);
const
l
=
store
.
state
.
noticeList
;
if
(
l
.
length
>=
5
){
l
.
shift
();
}
l
.
push
(
socket
);
const
n
=
{
notifyIndex
:
l
.
length
,
...
socket
}
store
.
commit
(
'updateNoticeList'
,
l
);
console
.
log
(
'--_VM'
,
_VM
)
const
{
path
}
=
_VM
.
$route
;
console
.
log
(
"n--------"
,
n
)
const
operateUserId
=
store
.
state
.
soketQuest
.
operateUserId
?
store
.
state
.
soketQuest
.
operateUserId
:
''
if
(
path
&&
String
(
path
).
indexOf
(
'workbench'
)
>
-
1
&&
n
.
operateUserId
==
operateUserId
){
store
.
commit
(
'socket/SET_NOTIFY'
,
n
);
}
});
state
.
socketClient
.
on
(
'ping'
,
function
()
{
console
.
log
(
'[E] 心跳请求已发出 →'
,
state
.
socketClient
);
if
(
socketTimer
){
clearInterval
(
socketTimer
);
}
});
//收到
state
.
socketClient
.
on
(
'pong'
,
function
(
socket
)
{
console
.
log
(
'[E] 心跳响应已收到 ←'
,
socket
,
state
.
socketClient
);
});
state
.
socketClient
.
io
.
on
(
"reconnect_attempt"
,
(
socket
)
=>
{
console
.
log
(
'--reconnect_attempt'
,
socket
);
// ...
});
state
.
socketClient
.
on
(
"reconnect"
,
(
socket
)
=>
{
console
.
log
(
'--reconnect'
,
socket
);
// ...
});
state
.
socketClient
.
on
(
'reconnecting'
,
(
attemptNumber
)
=>
{
// ...
console
.
log
(
'--reconnecting'
,
attemptNumber
);
});
},
//
SET_IOLISTION: (state, payload) => {
//
if(!state.socketClient){
//
return false;
//
}
//
state.socketClient.on("connect", (socket) => {
//
console.log ('socket 链接成功', socket, state.socketClient);
//
});
//
state.socketClient.on("connect_error", (err) => {
//
console.log ('socket connect_error',err);
//
// state.socketClient.connect();
//
});
//
state.socketClient.on("disconnect", (socket) => {
//
console.log ('socket disconnect----',socket);
//
// state.socketClient.connect();
//
});
//
state.socketClient.on("diagnose_push_event", (socket) => {
//
console.log('diagnose_push_event---', socket);
//
const {list,allSize,countRespList} = socket;
//
console.log('--_VM', _VM.$route)
//
store.commit('updateCurrentDiagList', list);
//
store.commit('updateAllSize', allSize);
//
store.commit('updateCurrentCalList', countRespList);
//
});
//
state.socketClient.on("diagnose_call_push_event", (socket) => {
//
console.log('diagnose_call_push_event---', socket);
//
const l = store.state.noticeList;
//
if(l.length >=5){
//
l.shift();
//
}
//
l.push(socket);
//
const n = {notifyIndex: l.length, ...socket}
//
store.commit('updateNoticeList', l);
//
console.log('--_VM', _VM)
//
const {path} =_VM.$route;
//
console.log("n--------",n)
//
const operateUserId=store.state.soketQuest.operateUserId?store.state.soketQuest.operateUserId:''
//
if(path && String(path).indexOf('workbench') > -1&&n.operateUserId==operateUserId){
//
store.commit('socket/SET_NOTIFY', n);
//
}
//
});
//
state.socketClient.on('ping', function () {
//
console.log('[E] 心跳请求已发出 →', state.socketClient);
//
if(socketTimer){
//
clearInterval(socketTimer);
//
}
//
});
//
//收到
//
state.socketClient.on('pong', function (socket) {
//
console.log('[E] 心跳响应已收到 ←', socket, state.socketClient);
//
});
//
state.socketClient.io.on("reconnect_attempt", (socket) => {
//
console.log('--reconnect_attempt', socket);
//
// ...
//
});
//
//
state.socketClient.on("reconnect", (socket) => {
//
console.log('--reconnect', socket);
//
// ...
//
});
//
state.socketClient.on('reconnecting', (attemptNumber) => {
//
// ...
//
console.log('--reconnecting', attemptNumber);
//
});
//
},
SET_NOTIFY
:
(
state
,
payload
)
=>
{
console
.
log
(
'--payload'
,
payload
)
let
doms
=
document
.
getElementsByClassName
(
'el-notification'
)
...
...
写
预览
Markdown
格式
0%
请重试
or
附加一个文件
附加文件
取消
您添加了
0
人
到此讨论。请谨慎行事。
先完成此消息的编辑!
取消
想要评论请
注册
或
登录