Commit fdb3dec3 by huangqy

111

parent 9bd99ef4
......@@ -278,7 +278,7 @@ export default defineComponent({
const logData = ref([])
const visible = ref(false)
const formData = ref({})
const activeTab = ref(1)
const activeTab = ref()
const activeNames = ref(['1','2','3', '4'])
const readerType = ref(4)
const title = ref()
......@@ -293,6 +293,7 @@ export default defineComponent({
const log = ref('')
const errList = ref([])
const showErr = ref(false)
const lockReconnect = ref(false)
const state = reactive({
url: {
......@@ -323,9 +324,9 @@ export default defineComponent({
// websocket开始
let websock = null
function initWebSocket () {
if (websock) {
return
}
// if (websock) {
// return
// }
websock = new WebSocket(window._CONFIG['wsURL'] + JSON.parse(sessionStorage.getItem('storeInfo')).storeCode);
websock.onopen = websocketOnopen;
websock.onerror = websocketOnerror;
......@@ -350,9 +351,13 @@ export default defineComponent({
logData.value = ''
if (message.noticeType == 0 && message.noticeInfo == 1) {
map1.set(message.stationId + 'd', 'green')
} else if ((message.noticeType == 0 && message.noticeInfo == 0) ) {
map1.set(message.stationId + 'd', '')
}
if (message.noticeType == 4 && message.noticeInfo == 1) {
map1.set(message.stationId + 'g', 'green')
} else if ((message.noticeType == 4 && message.noticeInfo == 0) ) {
map1.set(message.stationId + 'g', '')
}
let str = '<div>【通道' + message.stationId + ': ' + '</div><div class=' + (map1.get(message.stationId + 'd') || 'red')+ '></div><div>读写器</div><div class='+ (map1.get(message.stationId + 'g') || 'red') + '></div><div>GPIO</div>】'
map.set(message.stationId, str)
......@@ -406,21 +411,24 @@ export default defineComponent({
// Websoket连接错误事件
const websocketOnerror = (res) => {
console.log("WebSocket连接错误");
reconnect()
};
// Websoket断开事件
const websocketClose = (res) => {
console.log("WebSocket断开连接");
emit('logChange', logData.value.replaceAll('green', 'red'))
console.log(logData.value)
reconnect()
};
function reconnect() {
if(state.lockReconnect) return;
state.lockReconnect = true;
if(lockReconnect.value) return;
lockReconnect.value = true;
//没连接上会一直重连,设置延迟避免请求过多
setTimeout(function () {
console.log("尝试重连...");
setTimeout(() => {
console.log("尝试重连...,5秒一次");
initWebSocket();
state.lockReconnect = false;
lockReconnect.value = false;
}, 5000);
}
......@@ -445,6 +453,8 @@ export default defineComponent({
res.data.map((item, index) => {
channelList.value.push(Object.assign({}, item, { logData: [], errNum: 0 }))
})
activeTab.value = channelList.value[0].stationId
emit('logChange', "<div>【通道" + activeTab.value + ": </div><div class=red></div><div>读写器</div><div class=red></div><div>GPIO</div>】")
initWebSocket()
getAction(state.url.openReader, {storeCode: JSON.parse(sessionStorage.getItem('storeInfo')).storeCode}).then(res => {
......@@ -468,7 +478,6 @@ export default defineComponent({
function clearData() {
let channel = channelList.value.find(i => i.stationId == activeTab.value)
console.log(channel)
channel.logData = []
}
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论