<!DOCTYPE html>
|
<html lang="zh">
|
<head>
|
<meta charset="UTF-8">
|
<title>设备消息监控</title>
|
<style>
|
html, body {
|
height: 100%;
|
margin: 0;
|
background-color: #3C3F41;
|
}
|
|
table {
|
width: 100%;
|
table-layout: fixed;
|
border-collapse: collapse;
|
}
|
|
td {
|
height: inherit;
|
border: 1px solid #555;
|
}
|
|
select {
|
width: 210px;
|
height: 30px;
|
margin: 0 auto 5px auto;
|
color: #BABABA;
|
font-size: 16px;
|
padding: 2px;
|
border: 1px solid #646464;
|
background-color: #414141;
|
}
|
|
input {
|
width: 100px;
|
height: 23px;
|
color: #BABABA;
|
padding: 2px;
|
border: 1px solid #646464;
|
background-color: #414141;
|
}
|
|
button {
|
width: 90px;
|
color: #BABABA;
|
font-size: 18px;
|
border: 1px solid #4C708C;
|
background-color: #365880;
|
}
|
|
button:active {
|
color: #EEE;
|
border: 1px solid #6B96B4;
|
}
|
|
p {
|
color: #BABABA;
|
text-align: left;
|
white-space: pre-wrap;
|
word-wrap: break-word;
|
word-break: break-all;
|
}
|
|
a {
|
color: #FFF;
|
}
|
|
.cell {
|
height: inherit;
|
text-align: center;
|
display: flex;
|
flex-direction: column;
|
}
|
|
.textarea {
|
height: inherit;
|
overflow: auto;
|
background-color: #2B2B2B;
|
}
|
|
.tool {
|
padding: 10px 0 10px 0;
|
}
|
|
::-webkit-scrollbar {
|
width: 10px;
|
}
|
|
::-webkit-scrollbar-thumb {
|
background-color: #666;
|
}
|
|
::-webkit-scrollbar-thumb:hover {
|
background-color: #777;
|
}
|
</style>
|
</head>
|
|
<body>
|
<table id="dev_box">
|
<tr>
|
<td>
|
<div class="cell">
|
<div class="textarea" id="dev_text_[idx]"></div>
|
<div class="tool">
|
<select id="dev_sel_[idx]">[option]</select>
|
<input type="text" onkeyup="onSearch(this)">
|
<button type="button" onclick="onSub([idx])">订阅</button>
|
<button type="button" onclick="onUnsub([idx])">取消</button>
|
<button type="button" onclick="$('dev_text_[idx]').innerHTML=''">清空</button>
|
<button type="button" onclick="onExport([idx])">导出</button>
|
</div>
|
</div>
|
</td>
|
</tr>
|
</table>
|
<a href="?s=1,2" target="_blank">1*2</a>
|
<a href="?s=1,4" target="_blank">1*4</a>
|
<a href="?s=2,6" target="_blank">2*6</a>
|
|
<script type="text/javascript">
|
const $ = id => document.getElementById(id)
|
const reg = new RegExp('\\[([^\\[\\]]*?)]', 'igm')
|
const domain = '//' + window.location.host
|
const subscriptions = {}
|
let eventSource = null
|
let userId = null
|
|
function onRender(data) {
|
let options = '<option value="">没有可订阅的设备</option>\n'
|
if (data && data.length) {
|
options = '<option value="">---请选择订阅设备---</option>\n'
|
options += data.map(e => `<option value="${e.mobileNo}">${e.mobileNo} - ${e.plateNo}</option>`).join('\n')
|
}
|
|
let size = [1, 1]
|
const s = new URLSearchParams(window.location.search).get('s')
|
if (s) size = s.split(',')
|
const row = size[0] > 3 ? 3 : size[0]
|
const column = size[1] > 6 ? 6 : size[1]
|
|
const height = Math.floor((document.documentElement.clientHeight) / row) - 1
|
|
const table = $('dev_box')
|
const td = table.children[0].children[0].innerHTML
|
let html = ''
|
let idx = 0
|
|
for (let i = 0; i < row; i++) {
|
html += `<tr style="height: ${height}px">`
|
for (let j = 0; j < column; j++) {
|
html += td.replace(reg, (node, key) => ({idx: idx, option: options})[key])
|
++idx
|
}
|
html += '</tr>'
|
}
|
table.innerHTML = html
|
}
|
|
function onSearch(e) {
|
let select = e.previousElementSibling
|
if (!select.disabled) {
|
const options = select.querySelectorAll('option')
|
options[0].selected = true
|
let value = e.value
|
if (value) {
|
options.forEach(e => e.selected = (e.innerHTML.search(value) >= 0))
|
}
|
}
|
}
|
|
function onExport(idx) {
|
const data = $('dev_text_' + idx).innerText
|
if (data) {
|
const a = document.createElement('a')
|
a.download = $('dev_sel_' + idx).value + '_' + new Date().toLocaleString().replaceAll(/[^0-9]/g, '_') + '.txt'
|
a.href = 'data:text/plain;base64,' + btoa(unescape(encodeURIComponent(data)))
|
a.click()
|
}
|
}
|
|
function onSub(idx) {
|
const select = $('dev_sel_' + idx)
|
if (select.disabled) {
|
return
|
}
|
const clientId = select.value
|
if (!clientId) {
|
return
|
}
|
if (subscriptions[clientId]) {
|
alert(`同一设备[${clientId}]不能重复订阅`)
|
return
|
}
|
|
select.disabled = true
|
const text = $('dev_text_' + idx)
|
text.println = function (data) {
|
const c = this.scrollTop + this.offsetHeight + 4
|
const h = this.scrollHeight
|
|
const p = document.createElement('p')
|
p.append(new Date().toLocaleString().replaceAll('/', '-') + ' ')
|
p.append(data)
|
this.append(p)
|
|
if (c >= h)
|
this.scrollTop = this.scrollHeight
|
}
|
|
eventSource.addEventListener(clientId, subscriptions[clientId] = e => text.println(e.data))
|
|
fetch(`${domain}/sse/event?userId=${userId}&add=${clientId}`, {method: 'post'})
|
.then(res => res.json())
|
.then(res => text.println(res ? '开始订阅' : '订阅失败,请刷新页面'))
|
.catch(err => text.println('连接服务器失败'))
|
}
|
|
function onUnsub(idx) {
|
const select = $('dev_sel_' + idx)
|
const clientId = select.value
|
if (!clientId) {
|
return
|
}
|
|
fetch(`${domain}/sse/event?userId=${userId}&del=${clientId}`, {method: 'post'})
|
.then(res => res.json())
|
.then(res => {
|
if (res) {
|
console.log(`取消订阅设备[${clientId}]....`)
|
eventSource.removeEventListener(clientId, subscriptions[clientId])
|
delete subscriptions[clientId]
|
select.disabled = false
|
$('dev_text_' + idx).println('结束订阅')
|
}
|
}).catch(err => console.error(err))
|
}
|
|
window.onload = () => {
|
fetch(`${domain}/device/option`)
|
.then(res => res.json())
|
.then(res => {
|
onRender(res.data)
|
eventSource = new EventSource(`${domain}/sse/connect`)
|
eventSource.addEventListener('start', e => userId = e.data)
|
eventSource.addEventListener('open', e => console.log(`建立连接`))
|
eventSource.addEventListener('error', e => console.log(`断开连接`))
|
}).catch(err => console.error(err))
|
}
|
</script>
|
</body>
|
</html>
|
