-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathzx1.html
331 lines (310 loc) · 12.7 KB
/
zx1.html
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
<!DOCTYPE html>
<html lang="zh">
<head>
<meta charset="utf-8" />
<title>生理信号采集</title>
<script>
function isSerialAv() {
if ("serial" in navigator) {
console.log("Web Serial API is supported");
//const port = await navigator.serial.requestPort();
//const ports = await navigator.serial.getPorts();
}else {console.log("Web Serial API is not supported");}
};
function getCol(matrix, col){
var column = [];
for(var i=0; i<matrix.length; i++){
column.push(matrix[i][col]);
}return column;}
function stringToHex(str){
var val="";
for(var i = 0; i < str.length; i++){
if(val == ""){val = str.charCodeAt(i).toString(16);}
else{val += "," + str.charCodeAt(i).toString(16);}
}return val;}
</script>
</head>
<body>
<div id="contReader">
<h1>文件内容读取器</h1>
<input type="file" id="fileInput" accept="*">
<pre id="fileContent"></pre>
<script>
document.getElementById('fileInput').addEventListener(
'change', function (event) {
var file = event.target.files[0];
var reader = new FileReader();
reader.onload = function (event) {
document.getElementById('fileContent').textContent = event.target.result;
};
reader.readAsText(file);
});
</script>
</div><hr>
<div id="excelRdr">
<script src="./js/xlsx/xlsx.mini.min.js"></script>
<h1>excel内容读取器</h1>
<input type="file" id="excelFile" multiple />
<div id="exTable"></div>
<script>
const whereTable = "#exTable"
// 读取本地excel文件，读取Excel文件对象
function readWorkbookFromLocalFile(file, callback) {
var reader = new FileReader();
reader.onload = function(e) {
var data = e.target.result;
var workbook = XLSX.read(data, {type: 'binary'});
console.log(workbook);
if(callback) callback(workbook);
};
reader.readAsBinaryString(file);
}
// 转成csv 要注意Execel表格内容不能包含英文的,不然解析出来的数据格式会有问题
function readWorkbook(workbook,_sheet) {
if(!_sheet){var _sheet=0;}
var sheetNames = workbook.SheetNames; // 工作表名称集合
var worksheet = workbook.Sheets[sheetNames[_sheet]]; // 我们默认只读取第一张sheet
var csv = XLSX.utils.sheet_to_csv(worksheet);
//console.log(csv);
var rows = csv.split('\n'); // 转化为数组
//rows.pop(); // 最后一行没用的
//console.log(rows); // 打印输出的数组
let table = ``;
rows.forEach(v => {
let tr = ``;
let td = ``;
v.split(',').forEach(item => {
td += `<td>${item}</td>`
});
tr = `<tr>${td}</tr>`;
table += tr;
});
table = `<table>${table}</table>`;
document.querySelector(whereTable).innerHTML = table; // 显示table表格
return csvToArray(csv,0,0);//withoutHeader,as array.
}
// 将CSV数据转换为数组
function csvToArray(csvData,wizHeader,asArr) {
const lines = csvData.split('\n');
if(wizHeader){
const headers = lines[0].split(',');
const rows = lines.slice(1).map(line => line.split(','));
if(asArr){
const array = rows.map(row => {
var obj = new Array();
row.forEach((value, index) => {
obj.push(Number(value));
});return obj;
});return array;}
else{
const array = rows.map(row => {
const obj = {};
row.forEach((value, index) => {
obj[headers[index]] = Number(value);
});return obj;
});return array;}
}else{
const rows = lines.map(line => line.split(','));
const array = rows.map(row => {
var obj = new Array();
row.forEach((value, index) => {obj.push(Number(value));});
return obj;});
return array;}
}
</script>
<script>
var excelData;
document.querySelector('#excelFile').onchange = function (e) {
let file = e.target.files[0];//first sheet
readWorkbookFromLocalFile(file, function(workbook) {
excelData=readWorkbook(workbook);
});}
</script>
</div><hr>
<!--=============================================================================================================-->
<!--=============================================================================================================-->
<div id="comReader">
<script>
class singleData {//实时数据包类
constructor(rawData) {
this.header = rawData[0];
this.acData = rawData.slice(1,64).map(
function(i){return i-128});
this.heartRate=rawData[65];
this.spo2=rawData[66];
this.bk=rawData[67];
this.rsv=rawData.slice(68,75);
}
}
var isRreading = false;//读取控制
// 定义一个数组变量data，用来存储心率数据，初始为空
var HRdata = [];
var doDrop = false;
var displaysize=512;
</script>
<!--=============================================================================================================-->
<h1>USB串口读取</h1>
<button onclick="readFromSerialPort()">Read from Serial Port</button>
<button onclick="stopSerialPort()">Stop reading</button>
<button onclick="clearData()">cleardata</button>
<button onclick="clc()">clc</button>
<button onclick="toggleDrop()">toggleDrop</button>
<script type="text/javascript" src="./js/echarts/echarts.min.js"></script>
<div id="chart" style="width: 90%;height:400px;"></div>
<script>
var chart = echarts.init(document.getElementById('chart'));
// 设置图表的基本配置
var option = {
animation:false,
title: {text:'实时心率数据'},
tooltip: {trigger: 'axis'},
legend: {data: ['心率']},
xAxis: {data:[]},
yAxis: {type: 'value',min: -128,max: 127},
series: [{name: '心率',type: 'line',data: []}]
};
// 设置图表的初始数据
chart.setOption(option);
function process(signal){
// 使用滤波器来去除噪声，这里以平滑滤波器为例
const kernelSize = 5; // 滤波器大小
const kernel = new Array(kernelSize).fill(1 / kernelSize); // 归一化平滑滤波器
const smoothedSignal = signal.map((value, index) => {
let sum = 0;
for (let i = 0; i < kernelSize; i++) {
const indexOffset = index - i;
if (indexOffset < 0 || indexOffset >= signal.length) continue;
sum += kernel[i] * signal[indexOffset];
}
return sum;
});
const min = Math.min(...smoothedSignal);
const max = Math.max(...smoothedSignal);
const normalizedSignal = smoothedSignal.map((value) => (value - min) / (max - min));
let localMin = [];
let localMax = [];
for (let i = 1; i < normalizedSignal.length - 1; i++) {
if (normalizedSignal[i] < normalizedSignal[i - 1] && normalizedSignal[i] < normalizedSignal[i + 1]) {
localMin.push(i);
} else if (normalizedSignal[i] > normalizedSignal[i - 1] && normalizedSignal[i] > normalizedSignal[i + 1]) {
localMax.push(i);
}
}
let upperEnvelope = [];
let lowerEnvelope = [];
let polynomialOrder = 3; // 三次样条插值
for (let i = 0; i < normalizedSignal.length; i++) {
if (i % (polynomialOrder + 1) === 0) {
let x = normalizedSignal.slice(i, i + polynomialOrder + 1);
let y = extrema[0].concat(extrema[1]); // 极值点作为样条插值的端点
let spline = new Spline(x, y);
let upperPoint = spline.evaluate(normalizedSignal[i]);
let lowerPoint = spline.evaluate(normalizedSignal[i]) - normalizedSignal[i];
upperEnvelope.push(upperPoint);
lowerEnvelope.push(lowerPoint);
} else {
upperEnvelope.push(upperEnvelope[upperEnvelope.length - 1]);
lowerEnvelope.push(lowerEnvelope[lowerEnvelope.length - 1]);
}
}
let extrema = [upperEnvelope, lowerEnvelope];
let residual = normalizedSignal.slice(); // 残差作为IMF的一部分，初始化为原始数据
while (residual.length > 3 && extrema[0].length > 0) { // 当数据长度大于3且存在极值点时，进行迭代分解
let [localMin, localMax] = findLocalExtrema(residual); // 找到局部极值点
let [upperEnvelope, lowerEnvelope] = getEnvelope(residual, [localMin, localMax]); // 得到上下包络线
let meanValue = (upperEnvelope.reduce((a, b) => a + b, 0) + lowerEnvelope.reduce((a, b) => a + b, 0)) / 2; // 计算均值
let residualMean = residual.reduce((a, b) => a + b, 0) / residual.length; // 计算残差均值
let envelopeMean = (upperEnvelope.reduce((a, b) => a + b, 0) + lowerEnvelope.reduce((a, b) => a + b, 0)) / 2 / residualMean; // 计算包络线均值（标准化）
residual = residual.map((value, index) => value - envelopeMean * meanValue[index]); // 从原始数据中减去包络线均值与均值乘积得到新的残差
}
return residual; // 返回IMF分量（最后的残差）和极值点列表（用于迭代分解）
}
var _HRdata=process(HRdata);
// 定义一个函数updateData，用来每隔1.25秒从heartrate[]中获取最新的心率值，并追加到data中，同时更新图表的数据和视图
function updateData() {
let dpHRdata=[];
let dpSec=[];
for(let i=0;i<_HRdata.length;i++){
dpSec.push(i/50);
}
if(doDrop){
let start=_HRdata.length-displaysize;
if(start<0){start=0;}
dpHRdata=_HRdata.slice(start,_HRdata.length);
dpSec=dpSec.slice(start,_HRdata.length);
}
else{
dpHRdata=_HRdata;
}
//console.log(dpHRdata,dpSec);
// 更新图表的x轴和y轴的数据
chart.setOption({
xAxis:{data: dpSec},
series: [{data: dpHRdata}]
});
setTimeout(updateData, 128);//1280max,太小容易卡
}
updateData();// 调用updateData函数，开始显示实时心率数据
window.addEventListener('resize', chart.resize);
</script>
<hr>
<!--=============================================================================================================-->
<div id="serialData"><h5>data here</h5></div>
<script>
var rawHR = document.getElementById("serialData");
function toggleDrop(){doDrop =! doDrop;}
function clc(){HRdata=[];}
function clearData(){
var div = document.getElementById("serialData");
div.innerHTML = "<h5>data here</h5>";
}
function stopSerialPort(){isRreading = false;}
async function readFromSerialPort(){
var serial = navigator.serial;//从选择列表获取串口对象
var port = await serial.requestPort();//打开串口
isRreading = true;
//设置串口参数
//port.setTimeout(200);
await port.open({
baudRate:38400,
dataBits:8,
parity:"none",
stopBits:1,
bufferSize:8192
});
//发送数据0x8A
var writer = port.writable.getWriter();
await writer.write(Uint8Array.of(0x8A));
await writer.close();
//创建数据流读取器
var reader = port.readable.getReader();
//读取数据，直到isRreading被置为false
var l76data = new Array();
var d76l = 0;
while(isRreading){
var { value, done } = await reader.read();
if (value) {
for(var i=0;i<value.length;i++)
{l76data[d76l+i]=parseInt(value[i]);};
d76l+=value.length;
}else{continue;}
if(d76l>=76){
let tPdata = new singleData(l76data);
d76l=0;l76data=[];
HRdata.push(...tPdata.acData);
var p = document.createElement("plaintext");//新建一个p标签
p.innerHTML = tPdata.acData.join("\t");//将数据显示在p标签上
rawHR.appendChild(p);//将p标签添加到div上
}
};
//发送数据0x88，结束读取
var writer = port.writable.getWriter();
await writer.write(Uint8Array.of(0x88));
await writer.close();
reader.releaseLock();//释放资源，关闭串口
await port.close();
}
</script>
</div><hr>
</body>
</html>