From b5646e3f08bf45a27a3db92f5e27568a5448cb03 Mon Sep 17 00:00:00 2001
From: chenyc <501753378@qq.com>
Date: 星期二, 10 十二月 2024 12:34:11 +0800
Subject: [PATCH] 优化串口重连
---
src/samples/deviceApi/mbp7000.ts | 28
src/samples/deviceApi/M503.ts | 12
src/samples/deviceApi/oumulong-HBP-9030.ts | 161 +++-
src/samples/deviceApi/zhiRongT605.ts | 226 ++++++-
src/samples/deviceApi/RBP-9000c.ts | 196 ++++-
src/samples/deviceApi/taiHengM523.ts | 167 ++++-
src/samples/deviceApi/TM2655VP.ts | 186 +++++-
src/samples/deviceApi/liangjiang.ts | 12
src/samples/deviceApi/xinanguojiTZC.ts | 12
src/samples/deviceApi/zhiRongHehui.ts | 228 ++++++-
src/samples/deviceApi/mbp-9020.ts | 209 +++++-
src/samples/deviceApi/XK3190A12.ts | 268 ++++++--
electron/main/appVersion.ts | 5
13 files changed, 1,271 insertions(+), 439 deletions(-)
diff --git a/electron/main/appVersion.ts b/electron/main/appVersion.ts
index 3ce226f..90248e3 100644
--- a/electron/main/appVersion.ts
+++ b/electron/main/appVersion.ts
@@ -1,6 +1,6 @@
import { autoUpdater } from 'electron-updater';
import logger from 'electron-log'
-import { dialog, BrowserWindow } from 'electron';
+import { dialog, BrowserWindow, ipcRenderer } from 'electron';
const updateUrl = 'https://piclist.icoldchain.cn'
/**检测更新 */
@@ -23,7 +23,8 @@
//监听'error'事件
autoUpdater.on('error', err => {
console.log('出错拉' + err);
- dialog.showErrorBox('更新出错拉！', err.message);
+ ipcRenderer.invoke('logger', `更新中出现错误${err.message}`)
+ // dialog.showErrorBox('更新出错拉！可能网络', err.message);
});
//监听'update-available'事件，发现有新版本时触发
diff --git a/src/samples/deviceApi/M503.ts b/src/samples/deviceApi/M503.ts
index a36be68..28af862 100644
--- a/src/samples/deviceApi/M503.ts
+++ b/src/samples/deviceApi/M503.ts
@@ -1,4 +1,4 @@
-import { ElMessage, ElMessageBox } from 'element-plus'
+import { ElMessage, ElMessageBox, ElNotification } from 'element-plus'
const { SerialPort } = require('serialport')
const { DelimiterParser } = require('@serialport/parser-delimiter')
const { ReadyParser } = require('@serialport/parser-ready')
@@ -20,7 +20,7 @@
if(reconnectAttempts!==0){
console.log('ssss',reconnectAttempts)
ipcRenderer.invoke('logger', '串口重连第${reconnectAttempts}次')
- ElMessage({
+ ElMessage.warning({
message: `串口重连第${reconnectAttempts}次启动`,
type: 'success',
})
@@ -60,10 +60,12 @@
if (err) {
console.log(err)
ipcRenderer.invoke('logger', 'M503体重秤端口打开失败！')
- ElMessage({
+ ElNotification.warning({
+ title: '警告',
message: 'M503体重秤端口打开失败！',
- type: 'error',
- })
+ showClose: false,
+ duration:10000
+ })
setTimeout(()=>{
initPort(path,baudRate)
}, RECONNECT_INTERVAL);
diff --git a/src/samples/deviceApi/RBP-9000c.ts b/src/samples/deviceApi/RBP-9000c.ts
index f6dd278..91cd604 100644
--- a/src/samples/deviceApi/RBP-9000c.ts
+++ b/src/samples/deviceApi/RBP-9000c.ts
@@ -1,68 +1,156 @@
// 脉搏波 rbp-9000c 115200
-import { ElMessage } from 'element-plus'
+import { ElMessage, ElMessageBox, ElNotification } from 'element-plus'
const { SerialPort } = require('serialport')
const { DelimiterParser } = require('@serialport/parser-delimiter')
const { ByteLengthParser } = require('@serialport/parser-byte-length')
import {sockteStore} from '@/stores/sockteInfo'
+import { ipcRenderer } from 'electron'
-
+// 设置重连间隔和最大重试次数
+const RECONNECT_INTERVAL = 10000; // 重连间隔10秒
+const MAX_RECONNECT_ATTEMPTS = 10; // 最大重试次数10次
+
+let reconnectAttempts = 0; // 当前重试次数
+let serialPort:any; // 串口实例
const initPort=(path:String,baudRate:Number)=>{
- const serialport = new SerialPort({ path, baudRate }, (err: any) => {
- if (err) {
- console.log(err)
- ElMessage({
- message: '端口打开失败！',
- type: 'error',
+ if(reconnectAttempts!==0){
+ console.log('ssss',reconnectAttempts)
+ ipcRenderer.invoke('logger', '串口重连第${reconnectAttempts}次')
+ ElMessage.warning({
+ message: `串口重连第${reconnectAttempts}次启动`,
+ type: 'success',
+ })
+ }
+ if (reconnectAttempts >= MAX_RECONNECT_ATTEMPTS) {
+ console.error('重试次数达到上限，不再尝试重连。');
+ ipcRenderer.invoke('logger', '串口已经重连了${reconnectAttempts}次了，点击确认关闭程序，重启电脑后再试')
+ ElMessageBox.confirm(
+ `串口已经重连了${reconnectAttempts}次了，点击确认关闭程序，重启电脑后再试`,
+ 'Warning',
+ {
+ confirmButtonText: '确认',
+ cancelButtonText: '取消',
+ type: 'warning',
+ }
+ )
+ .then(() => {
+ ipcRenderer.send('winClose')
+ ipcRenderer.invoke('logger', '确认了关闭程序')
})
- console.log(err)
- }else{
- ElMessage({
- message: 'rbp-9000c端口打开成功',
- type: 'success',
+ .catch(() => {
+ ElMessage({
+ type: 'info',
+ message: '取消操作',
+ })
})
- }
- })
- serialport.on("close",(err: any)=>{
- console.log('端口异常端口链接断开')
- console.log(err)
- })
- // AA E0 03 28 64 02 71 06 44 51 A2 01 84 40 40 C0 5D D0
- // 解析分割数据流 AA 80 09 0F 01 06 00 17 05 0E 10 11 0F 00 8D 00 44 00 56 8C
- //AA 80 09 0F 01 06 00 17 05 0E 0F 37 37 00 74 00 46 00 50 70
- const parser = serialport.pipe(new ByteLengthParser({ length: 20 }))
- // parser.on('data', (value: string | any[])=>{
- // console.log(value.toString())
- // const str=value.toString()
- // const list=str.split(',')
- // console.log(list)
- // if(list.length===11){
- // sockteStore().setxyjSockte(
- // {
- // deviceName:'HBP-9030',
- // type:"血压计",
- // result:list[14]+','+list[16]+','+list[18],
- // resultTime:new Date().toString(),
- // state:2
- // }
- // )
- // }
+ return;
+ }
+
+ if (serialPort && serialPort.isOpen) {
+ reconnectAttempts=0
+ console.log('串口已打开，不再重复打开。');
+ return;
+ }
+ try {
+ serialPort = new SerialPort({ path, baudRate }, (err: any) => {
+ reconnectAttempts++
+ if (err) {
+ console.log(err)
+ ipcRenderer.invoke('logger', '血压计端口打开失败！')
+ ElNotification.warning({
+ title: '警告',
+ message: '血压计端口打开失败！',
+ showClose: false,
+ duration:10000
+ })
+
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ }else{
+ reconnectAttempts=0
+ ipcRenderer.invoke('logger', '血压计端口打开成功')
+ ElMessage.success({
+ message: '血压计端口打开成功',
+ type: 'success',
+ })
+ }
+ })
+ serialPort.on("close",(err: any)=>{
+ ipcRenderer.invoke('logger', ' 血压计端口异常端口链接关闭')
+ console.log(' 血压计端口异常端口链接断开')
+ reconnectAttempts=0
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ console.log(err)
+ })
+ // AA E0 03 28 64 02 71 06 44 51 A2 01 84 40 40 C0 5D D0
+ // 解析分割数据流 AA 80 09 0F 01 06 00 17 05 0E 10 11 0F 00 8D 00 44 00 56 8C
+ //AA 80 09 0F 01 06 00 17 05 0E 0F 37 37 00 74 00 46 00 50 70
+ // 9600
+ const parser = serialPort.pipe(new ByteLengthParser({ length: 20 }))
+ parser.on('data',(value: string | any[]) =>{
+ if(value.length>=20){
+ sockteStore().setxyjSockte(
+ {
+ deviceName:'RBP-9000c',
+ type:"血压计",
+ result:value[14]+','+value[16]+','+value[18],
+ resultTime:new Date().toString(),
+ state:2
+ }
+ )
+ }
+ console.log(value,'血压计数据')
+ })
+ }
+ catch (error:any) {
+ console.error('无法创建串口实例:', error.message);
+ reconnectAttempts=0
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ }
+ // const serialport = new SerialPort({ path, baudRate }, (err: any) => {
+ // if (err) {
+ // console.log(err)
+ // ElMessage({
+ // message: '端口打开失败！',
+ // type: 'error',
+ // })
+ // console.log(err)
+ // }else{
+ // ElMessage({
+ // message: 'rbp-9000c端口打开成功',
+ // type: 'success',
+ // })
+ // }
// })
- parser.on('data',(value: string | any[]) =>{
- console.log('-----------------')
- if(value.length>=20){
- sockteStore().setxyjSockte(
- {
- deviceName:'HBP-9030',
- type:"血压计",
- result:value[14]+','+value[16]+','+value[18],
- resultTime:new Date().toString(),
- state:2
- }
- )
- }
- console.log(value,'血压计数据')
- })
+ // serialport.on("close",(err: any)=>{
+ // console.log('端口异常端口链接断开')
+ // console.log(err)
+ // })
+ // // AA E0 03 28 64 02 71 06 44 51 A2 01 84 40 40 C0 5D D0
+ // // 解析分割数据流 AA 80 09 0F 01 06 00 17 05 0E 10 11 0F 00 8D 00 44 00 56 8C
+ // //AA 80 09 0F 01 06 00 17 05 0E 0F 37 37 00 74 00 46 00 50 70
+ // const parser = serialport.pipe(new ByteLengthParser({ length: 20 }))
+ // parser.on('data',(value: string | any[]) =>{
+ // console.log('-----------------')
+ // if(value.length>=20){
+ // sockteStore().setxyjSockte(
+ // {
+ // deviceName:'RBP-9000c',
+ // type:"血压计",
+ // result:value[14]+','+value[16]+','+value[18],
+ // resultTime:new Date().toString(),
+ // state:2
+ // }
+ // )
+ // }
+ // console.log(value,'血压计数据')
+ // })
}
export {
diff --git a/src/samples/deviceApi/TM2655VP.ts b/src/samples/deviceApi/TM2655VP.ts
index c94e0e1..78d387c 100644
--- a/src/samples/deviceApi/TM2655VP.ts
+++ b/src/samples/deviceApi/TM2655VP.ts
@@ -1,53 +1,161 @@
// 6.诊之助 TM2655VP
-import { ElMessage } from 'element-plus'
+import { ElMessage, ElMessageBox, ElNotification } from 'element-plus'
const { SerialPort } = require('serialport')
const { DelimiterParser } = require('@serialport/parser-delimiter')
const { ByteLengthParser } = require('@serialport/parser-byte-length')
import {sockteStore} from '@/stores/sockteInfo'
+import { ipcRenderer } from 'electron'
+// 设置重连间隔和最大重试次数
+const RECONNECT_INTERVAL = 10000; // 重连间隔10秒
+const MAX_RECONNECT_ATTEMPTS = 10; // 最大重试次数10次
+
+let reconnectAttempts = 0; // 当前重试次数
+let serialPort:any; // 串口实例
const initPort=(path:String,baudRate:Number)=>{
console.log('初始化打开诊之助 TM2655VP端口')
- const serialport = new SerialPort({ path, baudRate }, (err: any) => {
- if (err) {
- console.log(err)
- ElMessage({
- message: '诊之助 TM2655VP端口打开失败！',
- type: 'error',
- })
- console.log(err)
- }else{
- ElMessage({
- message: '诊之助 TM2655VP端口打开成功',
- type: 'success',
- })
- }
- })
- serialport.on("close",(err: any)=>{
- console.log('诊之助 TM2655VP端口异常端口链接断开')
- console.log(err)
- })
- // 解析分割数据流
- const parser = serialport.pipe(new ByteLengthParser({ length: 32*2 }))
- parser.on('data', (value: string | any[])=>{
- console.log(value.toString())
- const str=value.toString()
- console.log(str.length)
- const re=str.substring(34,37)+','+str.substring(39,41)+','+str.substring(44,46)
- console.log(re)
- if(str.length>=11){
- sockteStore().setxyjSockte(
- {
- deviceName:'TM2655VP',
- type:"血压计",
- result:str.substring(34,37)+','+str.substring(44,47)+','+str.substring(49,52),
- resultTime:new Date().toString(),
- state:2
- }
+ if(reconnectAttempts!==0){
+ console.log('ssss',reconnectAttempts)
+ ipcRenderer.invoke('logger', '串口重连第${reconnectAttempts}次')
+ ElMessage.warning({
+ message: `串口重连第${reconnectAttempts}次启动`,
+ type: 'success',
+ })
+ }
+ if (reconnectAttempts >= MAX_RECONNECT_ATTEMPTS) {
+ console.error('重试次数达到上限，不再尝试重连。');
+ ipcRenderer.invoke('logger', '串口已经重连了${reconnectAttempts}次了，点击确认关闭程序，重启电脑后再试')
+ ElMessageBox.confirm(
+ `串口已经重连了${reconnectAttempts}次了，点击确认关闭程序，重启电脑后再试`,
+ 'Warning',
+ {
+ confirmButtonText: '确认',
+ cancelButtonText: '取消',
+ type: 'warning',
+ }
)
- }
+ .then(() => {
+ ipcRenderer.send('winClose')
+ ipcRenderer.invoke('logger', '确认了关闭程序')
+ })
+ .catch(() => {
+ ElMessage({
+ type: 'info',
+ message: '取消操作',
+ })
+ })
+ return;
+ }
+ if (serialPort && serialPort.isOpen) {
+ reconnectAttempts=0
+ console.log('串口已打开，不再重复打开。');
+ return;
+ }
+ try {
+ const serialport = new SerialPort({ path, baudRate }, (err: any) => {
+ reconnectAttempts++
+ if (err) {
+ console.log(err)
+ ipcRenderer.invoke('logger', '诊之助端口打开失败！')
+ ElNotification.warning({
+ title: '警告',
+ message: '诊之助端口打开失败！',
+ showClose: false,
+ duration:10000
+ })
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ }else{
+ reconnectAttempts=0
+ ipcRenderer.invoke('logger', '诊之助端口打开成功')
+ ElMessage({
+ message: '诊之助端口打开成功',
+ type: 'success',
+ })
+ }
+ })
+ serialport.on("close",(err: any)=>{
+ ipcRenderer.invoke('logger', '诊之助端口异常端口链接关闭')
+ console.log('诊之助端口异常端口链接断开')
+ reconnectAttempts=0
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ console.log(err)
+ })
+ // // 解析分割数据流
+ const parser = serialport.pipe(new ByteLengthParser({ length: 32*2 }))
+ parser.on('data', (value: string | any[])=>{
+ console.log(value.toString())
+ const str=value.toString()
+ console.log(str.length)
+ const re=str.substring(34,37)+','+str.substring(39,41)+','+str.substring(44,46)
+ console.log(re)
+ if(str.length>=11){
+ sockteStore().setxyjSockte(
+ {
+ deviceName:'TM2655VP',
+ type:"血压计",
+ result:str.substring(34,37)+','+str.substring(44,47)+','+str.substring(49,52),
+ resultTime:new Date().toString(),
+ state:2
+ }
+ )
+ }
+
+ })
- })
+ }
+ catch (error:any) {
+ console.error('无法创建串口实例:', error.message);
+ reconnectAttempts=0
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ }
+
+ // const serialport = new SerialPort({ path, baudRate }, (err: any) => {
+ // if (err) {
+ // console.log(err)
+ // ElMessage({
+ // message: '诊之助 TM2655VP端口打开失败！',
+ // type: 'error',
+ // })
+ // console.log(err)
+ // }else{
+ // ElMessage({
+ // message: '诊之助 TM2655VP端口打开成功',
+ // type: 'success',
+ // })
+ // }
+ // })
+ // serialport.on("close",(err: any)=>{
+ // console.log('诊之助 TM2655VP端口异常端口链接断开')
+ // console.log(err)
+ // })
+ // // 解析分割数据流
+ // const parser = serialport.pipe(new ByteLengthParser({ length: 32*2 }))
+ // parser.on('data', (value: string | any[])=>{
+ // console.log(value.toString())
+ // const str=value.toString()
+ // console.log(str.length)
+ // const re=str.substring(34,37)+','+str.substring(39,41)+','+str.substring(44,46)
+ // console.log(re)
+ // if(str.length>=11){
+ // sockteStore().setxyjSockte(
+ // {
+ // deviceName:'TM2655VP',
+ // type:"血压计",
+ // result:str.substring(34,37)+','+str.substring(44,47)+','+str.substring(49,52),
+ // resultTime:new Date().toString(),
+ // state:2
+ // }
+ // )
+ // }
+
+ // })
}
export {
diff --git a/src/samples/deviceApi/XK3190A12.ts b/src/samples/deviceApi/XK3190A12.ts
index 066628b..d5e087e 100644
--- a/src/samples/deviceApi/XK3190A12.ts
+++ b/src/samples/deviceApi/XK3190A12.ts
@@ -1,10 +1,19 @@
// 耀华XK3190-A12
-import { ElMessage } from 'element-plus'
+import { ElMessage, ElMessageBox } from 'element-plus'
const { SerialPort } = require('serialport')
const { DelimiterParser } = require('@serialport/parser-delimiter')
const { ReadyParser } = require('@serialport/parser-ready')
import {sockteStore} from '@/stores/sockteInfo'
import { confingInfoStore } from '@/stores/StoresConfing'
+import { ipcRenderer } from 'electron'
+
+
+// 设置重连间隔和最大重试次数
+const RECONNECT_INTERVAL = 10000; // 重连间隔10秒
+const MAX_RECONNECT_ATTEMPTS = 10; // 最大重试次数10次
+
+let reconnectAttempts = 0; // 当前重试次数
+let serialPort:any; // 串口实例
const initPort=(path:String,baudRate:Number)=>{
// 是否清零了
@@ -14,80 +23,203 @@
console.log('初始化打开XK3190-A12体重秤端口',yanjiancishu)
let lisijieguo=''
let duibinum=0
- const serialport = new SerialPort({ path, baudRate }, (err: any) => {
- if (err) {
- console.log(err)
- ElMessage({
- message: 'XK3190-A12体重秤端口打开失败！',
- type: 'error',
+ if(reconnectAttempts!==0){
+ console.log('ssss',reconnectAttempts)
+ ipcRenderer.invoke('logger', '串口重连第${reconnectAttempts}次')
+ ElMessage({
+ message: `串口重连第${reconnectAttempts}次启动`,
+ type: 'success',
+ })
+ }
+ if (reconnectAttempts >= MAX_RECONNECT_ATTEMPTS) {
+ console.error('重试次数达到上限，不再尝试重连。');
+ ipcRenderer.invoke('logger', `串口已经重连了${reconnectAttempts}次了，点击确认关闭程序，重启电脑后再试`)
+ ElMessageBox.confirm(
+ `串口已经重连了${reconnectAttempts}次了，点击确认关闭程序，重启电脑后再试`,
+ 'Warning',
+ {
+ confirmButtonText: '确认',
+ cancelButtonText: '取消',
+ type: 'warning',
+ }
+ )
+ .then(() => {
+ ipcRenderer.send('winClose')
+ ipcRenderer.invoke('logger', '确认了关闭程序')
})
- console.log(err)
- }else{
- ElMessage({
- message: 'XK3190-A12体重秤端口打开成功',
- type: 'success',
+ .catch(() => {
+ ElMessage({
+ type: 'info',
+ message: '取消操作',
+ })
})
- }
- })
- serialport.on("close",(err: any)=>{
- console.log('XK3190-A12体重秤端口异常端口链接断开')
- console.log(err)
- })
- // 解析分割数据流
- //
- //
- //
- //
- //
- // 77 6E 30 30 30 30 30 2E 30 6B 67 0D 0A
- // 77 6E 30 30 30 30 32 38 2E 36 6B 67 0D 0A
- // 77 6E 30 30 30 30 32 38 2E 36 6B 67 0D 0A
- //wn000016.6kg
- const parser = serialport.pipe(new DelimiterParser({ delimiter:Buffer.from([107,103,13,10]),includeDelimiter:true }))
- parser.on('data', (value: string | any[])=>{
- console.log(value.toString())
- const str=value.toString()
- // 截取结果
- // const list=str.substring(2,10) 得到数字
+ return;
+ }
+ if (serialPort && serialPort.isOpen) {
+ reconnectAttempts=0
+ console.log('串口已打开，不再重复打开。');
+ return;
+ }
+ try {
+ const serialport = new SerialPort({ path, baudRate }, (err: any) => {
+ reconnectAttempts++
+ if (err) {
+ console.log(err)
+ ipcRenderer.invoke('logger', ' XK3190-A12端口打开失败！')
+ ElMessage({
+ message: ' XK3190-A12端口打开失败！',
+ type: 'error',
+ })
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ }else{
+ reconnectAttempts=0
+ ipcRenderer.invoke('logger', ' XK3190-A12端口打开成功')
+ ElMessage({
+ message: ' XK3190-A12端口打开成功',
+ type: 'success',
+ })
+ }
+ })
+ serialport.on("close",(err: any)=>{
+ ipcRenderer.invoke('logger', ' XK3190-A12端口异常端口链接关闭')
+ console.log(' XK3190-A12端口异常端口链接断开')
+ reconnectAttempts=0
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ console.log(err)
+ })
+ // 解析分割数据流
+ // 77 6E 30 30 30 30 30 2E 30 6B 67 0D 0A
+ // 77 6E 30 30 30 30 32 38 2E 36 6B 67 0D 0A
+ // 77 6E 30 30 30 30 32 38 2E 36 6B 67 0D 0A
+ //wn000016.6kg
+ const parser = serialport.pipe(new DelimiterParser({ delimiter:Buffer.from([107,103,13,10]),includeDelimiter:true }))
+ parser.on('data', (value: string | any[])=>{
+ console.log(value.toString())
+ const str=value.toString()
+ // 截取结果
+ // const list=str.substring(2,10) 得到数字
- const list = parseFloat(str.replace(/[^\d.]/g, '')).toString();
- console.log(list)
- if(Number(list)>20){
- // 判断是否相等 相等加一
- if(list===lisijieguo){
- duibinum++
+ const list = parseFloat(str.replace(/[^\d.]/g, '')).toString();
+ console.log(list)
+ if(Number(list)>20){
+ // 判断是否相等 相等加一
+ if(list===lisijieguo){
+ duibinum++
+ }else{
+ lisijieguo=list
+ duibinum=0
+ }
+ // 对比4次结果都一致
+ if(duibinum>=yanjiancishu){
+ // 数据发送 体重没有清零 下次就不播报不发送
+ sfqingling=false
+ const res=Number(list)
+ console.log(res,'获取到的体重')
+ sockteStore().setweightSockte(
+ {
+ deviceName:'XK3190-A12',
+ type:"体重秤",
+ result:res.toString(),
+ resultTime:new Date().toString(),
+ state:2
+ }
+ )
+ duibinum=0
+ lisijieguo=''
+ }else{
+ // sfqingling=false
+ }
+
+
+
}else{
- lisijieguo=list
- duibinum=0
- }
- // 对比4次结果都一致
- if(duibinum>=yanjiancishu){
- // 数据发送 体重没有清零 下次就不播报不发送
- sfqingling=false
- const res=Number(list)
- console.log(res,'获取到的体重')
- sockteStore().setweightSockte(
- {
- deviceName:'XK3190-A12',
- type:"体重秤",
- result:res.toString(),
- resultTime:new Date().toString(),
- state:2
- }
- )
- duibinum=0
- lisijieguo=''
- }else{
- // sfqingling=false
- }
+ sfqingling=true
+ console.log('小于20')
+ }
+ }) // all data after READY is received
+ }
+ catch (error:any) {
+ console.error('无法创建串口实例:', error.message);
+ reconnectAttempts=0
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ }
+
+
+ // const serialport = new SerialPort({ path, baudRate }, (err: any) => {
+ // if (err) {
+ // console.log(err)
+ // ElMessage({
+ // message: 'XK3190-A12体重秤端口打开失败！',
+ // type: 'error',
+ // })
+ // console.log(err)
+ // }else{
+ // ElMessage({
+ // message: 'XK3190-A12体重秤端口打开成功',
+ // type: 'success',
+ // })
+ // }
+ // })
+ // serialport.on("close",(err: any)=>{
+ // console.log('XK3190-A12体重秤端口异常端口链接断开')
+ // console.log(err)
+ // })
+ // // 解析分割数据流
+ // // 77 6E 30 30 30 30 30 2E 30 6B 67 0D 0A
+ // // 77 6E 30 30 30 30 32 38 2E 36 6B 67 0D 0A
+ // // 77 6E 30 30 30 30 32 38 2E 36 6B 67 0D 0A
+ // //wn000016.6kg
+ // const parser = serialport.pipe(new DelimiterParser({ delimiter:Buffer.from([107,103,13,10]),includeDelimiter:true }))
+ // parser.on('data', (value: string | any[])=>{
+ // console.log(value.toString())
+ // const str=value.toString()
+ // // 截取结果
+ // // const list=str.substring(2,10) 得到数字
+
+ // const list = parseFloat(str.replace(/[^\d.]/g, '')).toString();
+ // console.log(list)
+ // if(Number(list)>20){
+ // // 判断是否相等 相等加一
+ // if(list===lisijieguo){
+ // duibinum++
+ // }else{
+ // lisijieguo=list
+ // duibinum=0
+ // }
+ // // 对比4次结果都一致
+ // if(duibinum>=yanjiancishu){
+ // // 数据发送 体重没有清零 下次就不播报不发送
+ // sfqingling=false
+ // const res=Number(list)
+ // console.log(res,'获取到的体重')
+ // sockteStore().setweightSockte(
+ // {
+ // deviceName:'XK3190-A12',
+ // type:"体重秤",
+ // result:res.toString(),
+ // resultTime:new Date().toString(),
+ // state:2
+ // }
+ // )
+ // duibinum=0
+ // lisijieguo=''
+ // }else{
+ // // sfqingling=false
+ // }
- }else{
- sfqingling=true
- console.log('小于20')
- }
- }) // all data after READY is received
+ // }else{
+ // sfqingling=true
+ // console.log('小于20')
+ // }
+ // }) // all data after READY is received
}
export {
diff --git a/src/samples/deviceApi/liangjiang.ts b/src/samples/deviceApi/liangjiang.ts
index a57a3da..16c1645 100644
--- a/src/samples/deviceApi/liangjiang.ts
+++ b/src/samples/deviceApi/liangjiang.ts
@@ -1,5 +1,5 @@
// 欧姆龙 HBP-9030 115200
-import { ElMessage, ElMessageBox } from 'element-plus'
+import { ElMessage, ElMessageBox, ElNotification } from 'element-plus'
const { SerialPort } = require('serialport')
const { DelimiterParser } = require('@serialport/parser-delimiter')
const { ReadyParser } = require('@serialport/parser-ready')
@@ -61,10 +61,12 @@
if (err) {
console.log(err)
ipcRenderer.invoke('logger', 'lianjiang体重秤端口打开失败！')
- ElMessage({
- message: 'lianjiang体重秤端口打开失败！',
- type: 'error',
- })
+ ElNotification.warning({
+ title: '警告',
+ message: 'lianjiang体重秤端口打开失败！！',
+ showClose: false,
+ duration:10000
+ })
setTimeout(()=>{
initPort(path,baudRate)
}, RECONNECT_INTERVAL);
diff --git a/src/samples/deviceApi/mbp-9020.ts b/src/samples/deviceApi/mbp-9020.ts
index 3c3c474..3120596 100644
--- a/src/samples/deviceApi/mbp-9020.ts
+++ b/src/samples/deviceApi/mbp-9020.ts
@@ -1,59 +1,176 @@
// 欧姆龙 HBP-9030 115200
-import { ElMessage } from 'element-plus'
+import { ElMessage, ElMessageBox, ElNotification } from 'element-plus'
const { SerialPort } = require('serialport')
const { DelimiterParser } = require('@serialport/parser-delimiter')
const { ReadyParser } = require('@serialport/parser-ready')
import {sockteStore} from '@/stores/sockteInfo'
+import { ipcRenderer } from 'electron'
+
+// 设置重连间隔和最大重试次数
+const RECONNECT_INTERVAL = 10000; // 重连间隔10秒
+const MAX_RECONNECT_ATTEMPTS = 10; // 最大重试次数10次
+
+let reconnectAttempts = 0; // 当前重试次数
+let serialPort:any; // 串口实例
const initPort=(path:String,baudRate:Number)=>{
- console.log('初始化打开mbp9020血压计端口')
- const serialport = new SerialPort({ path, baudRate }, (err: any) => {
- if (err) {
- console.log(err)
- ElMessage({
- message: 'mbp9020血压计端口打开失败！',
- type: 'error',
+ console.log('初始化打开mbp9020体重秤端口',reconnectAttempts)
+ if(reconnectAttempts!==0){
+ console.log('ssss',reconnectAttempts)
+ ipcRenderer.invoke('logger', '串口重连第${reconnectAttempts}次')
+ ElMessage.warning({
+ message: `串口重连第${reconnectAttempts}次启动`,
+ type: 'success',
+ })
+ }
+ if (reconnectAttempts >= MAX_RECONNECT_ATTEMPTS) {
+ console.error('重试次数达到上限，不再尝试重连。');
+ ipcRenderer.invoke('logger', '串口已经重连了${reconnectAttempts}次了，点击确认关闭程序，重启电脑后再试')
+ ElMessageBox.confirm(
+ `串口已经重连了${reconnectAttempts}次了，点击确认关闭程序，重启电脑后再试`,
+ 'Warning',
+ {
+ confirmButtonText: '确认',
+ cancelButtonText: '取消',
+ type: 'warning',
+ }
+ )
+ .then(() => {
+ ipcRenderer.send('winClose')
+ ipcRenderer.invoke('logger', '确认了关闭程序')
})
- console.log(err)
- }else{
- ElMessage({
- message: 'mbp9020血压计端口打开成功',
- type: 'success',
+ .catch(() => {
+ ElMessage({
+ type: 'info',
+ message: '取消操作',
+ })
})
- }
- })
- serialport.on("close",(err: any)=>{
- console.log('mbp9020血压计端口异常端口链接断开')
- console.log(err)
- })
- // 解析分割数据流
- //bp,99999999999999999999,2024/04/26,20:41,116,083,067,099,1
- //
- // 2400波特率
- //
- //62 70 2C39 39 39 39 39 39 39 39 39 39 39 39 39 3939 39 39 39 39 39 2C 32 30 32 34 2F 3037 2F 30 35 2C 32 30 3A 30 39 2C 31 31 392C 30 39 32 2C 30 37 39 2C 30 38 39 2C31 0D
- //
- // 62 702C 39 39 39 39 39 39 39 39 39 39 39 3939 39 39 39 39 39 39 39 2C 32 30 32 34 2F 30 34 2F32 36 2C 32 30 3A 34 36 2C 31 31 38 2C 30 38 31 2C30 36 33 2C 30 39 35 2C 30 0D
- const parser = serialport.pipe(new DelimiterParser({ delimiter:Buffer.from([13]),includeDelimiter:true }))
- parser.on('data', (value: string | any[])=>{
- console.log(value.toString())
- const str=value.toString()
- const list=str.split(',')
- console.log(list)
- if(list.length>=5&&list[0].search('bp')!==-1){
- sockteStore().setxyjSockte(
- {
- deviceName:'mbp9020',
- type:"血压计",
- result:list[4]+','+list[6]+','+list[7],
- resultTime:new Date().toString(),
- state:2
- }
- )
- }else{
- console.log('数据格式不对')
+ return;
+ }
+
+ if (serialPort && serialPort.isOpen) {
+ reconnectAttempts=0
+ console.log('串口已打开，不再重复打开。');
+ return;
+ }
+ try {
+ serialPort = new SerialPort({ path, baudRate }, (err: any) => {
+ reconnectAttempts++
+ if (err) {
+ console.log(err)
+ ipcRenderer.invoke('logger', 'mbp9020血压计端口打开失败！')
+ ElNotification.warning({
+ title: '警告',
+ message: 'mbp9020血压计端口打开失败！',
+ showClose: false,
+ duration:10000
+ })
+
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ }else{
+ reconnectAttempts=0
+ ipcRenderer.invoke('logger', 'mbp9020血压计端口打开成功')
+ ElMessage.success({
+ message: 'mbp9020血压计端口打开成功',
+ type: 'success',
+ })
+ }
+ })
+ serialPort.on("close",(err: any)=>{
+ ipcRenderer.invoke('logger', 'mbp9020血压计端口异常端口链接关闭')
+ console.log('mbp9020血压计端口异常端口链接断开')
+ reconnectAttempts=0
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ console.log(err)
+ })
+ /// 解析分割数据流
+ //bp,99999999999999999999,2024/04/26,20:41,116,083,067,099,1
+ //
+ // 2400波特率
+ //
+ //62 70 2C39 39 39 39 39 39 39 39 39 39 39 39 39 3939 39 39 39 39 39 2C 32 30 32 34 2F 3037 2F 30 35 2C 32 30 3A 30 39 2C 31 31 392C 30 39 32 2C 30 37 39 2C 30 38 39 2C31 0D
+ //
+ // 62 702C 39 39 39 39 39 39 39 39 39 39 39 3939 39 39 39 39 39 39 39 2C 32 30 32 34 2F 30 34 2F32 36 2C 32 30 3A 34 36 2C 31 31 38 2C 30 38 31 2C30 36 33 2C 30 39 35 2C 30 0D
+ const parser = serialPort.pipe(new DelimiterParser({ delimiter:Buffer.from([13]),includeDelimiter:true }))
+ parser.on('data', (value: string | any[])=>{
+ console.log(value.toString())
+ const str=value.toString()
+ const list=str.split(',')
+ console.log(list)
+ if(list.length>=5&&list[0].search('bp')!==-1){
+ sockteStore().setxyjSockte(
+ {
+ deviceName:'mbp9020',
+ type:"血压计",
+ result:list[4]+','+list[6]+','+list[7],
+ resultTime:new Date().toString(),
+ state:2
+ }
+ )
+ }else{
+ console.log('数据格式不对')
+ }
+ }) // all data after READY is received
+
}
- }) // all data after READY is received
+ catch (error:any) {
+ console.error('无法创建串口实例:', error.message);
+ reconnectAttempts=0
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ }
+ // const serialport = new SerialPort({ path, baudRate }, (err: any) => {
+ // if (err) {
+ // console.log(err)
+ // ElMessage({
+ // message: 'mbp9020血压计端口打开失败！',
+ // type: 'error',
+ // })
+ // console.log(err)
+ // }else{
+ // ElMessage({
+ // message: 'mbp9020血压计端口打开成功',
+ // type: 'success',
+ // })
+ // }
+ // })
+ // serialport.on("close",(err: any)=>{
+ // console.log('mbp9020血压计端口异常端口链接断开')
+ // console.log(err)
+ // })
+ // // 解析分割数据流
+ // //bp,99999999999999999999,2024/04/26,20:41,116,083,067,099,1
+ // //
+ // // 2400波特率
+ // //
+ // //62 70 2C39 39 39 39 39 39 39 39 39 39 39 39 39 3939 39 39 39 39 39 2C 32 30 32 34 2F 3037 2F 30 35 2C 32 30 3A 30 39 2C 31 31 392C 30 39 32 2C 30 37 39 2C 30 38 39 2C31 0D
+ // //
+ // // 62 702C 39 39 39 39 39 39 39 39 39 39 39 3939 39 39 39 39 39 39 39 2C 32 30 32 34 2F 30 34 2F32 36 2C 32 30 3A 34 36 2C 31 31 38 2C 30 38 31 2C30 36 33 2C 30 39 35 2C 30 0D
+ // const parser = serialport.pipe(new DelimiterParser({ delimiter:Buffer.from([13]),includeDelimiter:true }))
+ // parser.on('data', (value: string | any[])=>{
+ // console.log(value.toString())
+ // const str=value.toString()
+ // const list=str.split(',')
+ // console.log(list)
+ // if(list.length>=5&&list[0].search('bp')!==-1){
+ // sockteStore().setxyjSockte(
+ // {
+ // deviceName:'mbp9020',
+ // type:"血压计",
+ // result:list[4]+','+list[6]+','+list[7],
+ // resultTime:new Date().toString(),
+ // state:2
+ // }
+ // )
+ // }else{
+ // console.log('数据格式不对')
+ // }
+ // }) // all data after READY is received
}
export {
diff --git a/src/samples/deviceApi/mbp7000.ts b/src/samples/deviceApi/mbp7000.ts
index f1005f9..de51cab 100644
--- a/src/samples/deviceApi/mbp7000.ts
+++ b/src/samples/deviceApi/mbp7000.ts
@@ -1,5 +1,5 @@
-import { ElMessage, ElMessageBox } from 'element-plus'
+import { ElMessage, ElMessageBox, ElNotification } from 'element-plus'
const { SerialPort } = require('serialport')
const { DelimiterParser } = require('@serialport/parser-delimiter')
const { InterByteTimeoutParser } = require('@serialport/parser-inter-byte-timeout')
@@ -21,7 +21,7 @@
console.log('初始化打开mbp7000口')
if(reconnectAttempts!==0){
ipcRenderer.invoke('logger', '串口重连第${reconnectAttempts}次')
- ElMessage({
+ ElMessage.warning({
message: `串口重连第${reconnectAttempts}次启动`,
type: 'success',
})
@@ -58,16 +58,25 @@
}
try {
serialPort = new SerialPort({ path, baudRate }, (err: any) => {
+ reconnectAttempts++
if (err) {
console.log(err)
- ElMessage({
- message: '端口打开失败！',
- type: 'error',
- })
- console.log(err)
+ ipcRenderer.invoke('logger', 'mbp7000血压计端口打开失败！')
+ ElNotification.warning({
+ title: '警告',
+ message: 'mbp7000血压计端口打开失败！',
+ showClose: false,
+ duration:10000
+ })
+
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
}else{
- ElMessage({
- message: '端口打开成功',
+ reconnectAttempts=0
+ ipcRenderer.invoke('logger', 'mbp7000血压计端口打开成功')
+ ElMessage.success({
+ message: 'mbp7000血压计端口打开成功',
type: 'success',
})
}
@@ -84,7 +93,6 @@
const parser = serialPort.pipe(new InterByteTimeoutParser({ interval: 500 ,maxBufferSize:20}))
parser.on('ready', () => console.log('the ready byte sequence has been received'))
-
parser.on('data',(value: string | any[]) =>{
console.log('-----------------')
if(value.length>=20){
diff --git a/src/samples/deviceApi/oumulong-HBP-9030.ts b/src/samples/deviceApi/oumulong-HBP-9030.ts
index 5c7773c..ecfff8c 100644
--- a/src/samples/deviceApi/oumulong-HBP-9030.ts
+++ b/src/samples/deviceApi/oumulong-HBP-9030.ts
@@ -1,64 +1,123 @@
// 欧姆龙 HBP-9030 115200
-import { ElMessage } from 'element-plus'
+import { ElMessage, ElMessageBox, ElNotification } from 'element-plus'
import { ipcRenderer } from 'electron'
const { SerialPort } = require('serialport')
const { DelimiterParser } = require('@serialport/parser-delimiter')
const { ByteLengthParser } = require('@serialport/parser-byte-length')
import {sockteStore} from '@/stores/sockteInfo'
+// 设置重连间隔和最大重试次数
+const RECONNECT_INTERVAL = 10000; // 重连间隔10秒
+const MAX_RECONNECT_ATTEMPTS = 10; // 最大重试次数10次
+
+let reconnectAttempts = 0; // 当前重试次数
+let serialPort:any; // 串口实例
const initPort=(path:String,baudRate:Number)=>{
- console.log('初始化打开测温端口')
- const serialport = new SerialPort({ path, baudRate }, (err: any) => {
- if (err) {
- console.log(err)
- ElMessage({
- message: '端口打开失败！',
- type: 'error',
- })
- ipcRenderer.invoke('logger', '端口打开失败')
- console.log(err)
- }else{
- ElMessage({
- message: '端口打开成功',
- type: 'success',
- })
- ipcRenderer.invoke('logger', '端口打开成功')
- }
- })
- serialport.on("close",(err: any)=>{
- console.log('端口异常端口链接断开')
- console.log(err)
- ipcRenderer.invoke('logger', '端口关闭了')
- })
- serialport.on("error",(err: any)=>{
- console.log('端口异常端口链接断开')
- console.log(err)
- ipcRenderer.invoke('logger', '端口异常断开')
- })
- // 解析分割数据流
- const parser = serialport.pipe(new ByteLengthParser({ length: 14*4-1 }))
- parser.on('data', (value: string | any[])=>{
- console.log(value.toString())
- ipcRenderer.invoke('logger', '串口消息')
- ipcRenderer.invoke('logger', value)
- ipcRenderer.invoke('logger', value.toString())
- const str=value.toString()
- const list=str.split(',')
- console.log(list)
- if(list.length===11){
- sockteStore().setxyjSockte(
- {
- deviceName:'HBP-9030',
- type:"血压计",
- result:list[7]+','+list[8]+','+list[9],
- resultTime:new Date().toString(),
- state:2
- }
+ console.log('初始化打开oumulong-HBP-9030端口',reconnectAttempts)
+ if(reconnectAttempts!==0){
+ console.log('ssss',reconnectAttempts)
+ ipcRenderer.invoke('logger', '串口重连第${reconnectAttempts}次')
+ ElMessage.warning({
+ message: `串口重连第${reconnectAttempts}次启动`,
+ type: 'success',
+ })
+ }
+ if (reconnectAttempts >= MAX_RECONNECT_ATTEMPTS) {
+ console.error('重试次数达到上限，不再尝试重连。');
+ ipcRenderer.invoke('logger', '串口已经重连了${reconnectAttempts}次了，点击确认关闭程序，重启电脑后再试')
+ ElMessageBox.confirm(
+ `串口已经重连了${reconnectAttempts}次了，点击确认关闭程序，重启电脑后再试`,
+ 'Warning',
+ {
+ confirmButtonText: '确认',
+ cancelButtonText: '取消',
+ type: 'warning',
+ }
)
- }
-
- })
+ .then(() => {
+ ipcRenderer.send('winClose')
+ ipcRenderer.invoke('logger', '确认了关闭程序')
+ })
+ .catch(() => {
+ ElMessage({
+ type: 'info',
+ message: '取消操作',
+ })
+ })
+ return;
+ }
+
+ if (serialPort && serialPort.isOpen) {
+ reconnectAttempts=0
+ console.log('串口已打开，不再重复打开。');
+ return;
+ }
+ try {
+ serialPort = new SerialPort({ path, baudRate }, (err: any) => {
+ reconnectAttempts++
+ if (err) {
+ console.log(err)
+ ipcRenderer.invoke('logger', '血压计端口打开失败！')
+ ElNotification.warning({
+ title: '警告',
+ message: '血压计端口打开失败！',
+ showClose: false,
+ duration:10000
+ })
+
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ }else{
+ reconnectAttempts=0
+ ipcRenderer.invoke('logger', '血压计端口打开成功')
+ ElMessage.success({
+ message: '血压计端口打开成功',
+ type: 'success',
+ })
+ }
+ })
+ serialPort.on("close",(err: any)=>{
+ ipcRenderer.invoke('logger', 'mbp9020血压计端口异常端口链接关闭')
+ console.log('mbp9020血压计端口异常端口链接断开')
+ reconnectAttempts=0
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ console.log(err)
+ })
+ // 解析分割数据流
+ const parser = serialPort.pipe(new ByteLengthParser({ length: 14*4-1 }))
+ parser.on('data', (value: string | any[])=>{
+ console.log(value.toString())
+ ipcRenderer.invoke('logger', '串口消息')
+ ipcRenderer.invoke('logger', value)
+ ipcRenderer.invoke('logger', value.toString())
+ const str=value.toString()
+ const list=str.split(',')
+ console.log(list)
+ if(list.length===11){
+ sockteStore().setxyjSockte(
+ {
+ deviceName:'HBP-9030',
+ type:"血压计",
+ result:list[7]+','+list[8]+','+list[9],
+ resultTime:new Date().toString(),
+ state:2
+ }
+ )
+ }
+
+ })
+ }
+ catch (error:any) {
+ console.error('无法创建串口实例:', error.message);
+ reconnectAttempts=0
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ }
}
export {
diff --git a/src/samples/deviceApi/taiHengM523.ts b/src/samples/deviceApi/taiHengM523.ts
index 2d1d02f..b0f4279 100644
--- a/src/samples/deviceApi/taiHengM523.ts
+++ b/src/samples/deviceApi/taiHengM523.ts
@@ -1,62 +1,131 @@
// 欧姆龙 HBP-9030 115200
-import { ElMessage } from 'element-plus'
+import { ElMessage, ElMessageBox } from 'element-plus'
const { SerialPort } = require('serialport')
const { DelimiterParser } = require('@serialport/parser-delimiter')
const { ReadyParser } = require('@serialport/parser-ready')
import {sockteStore} from '@/stores/sockteInfo'
+import { ipcRenderer } from 'electron'
+
+
+
+// 设置重连间隔和最大重试次数
+const RECONNECT_INTERVAL = 10000; // 重连间隔10秒
+const MAX_RECONNECT_ATTEMPTS = 10; // 最大重试次数10次
+
+let reconnectAttempts = 0; // 当前重试次数
+let serialPort:any; // 串口实例
+
const initPort=(path:String,baudRate:Number)=>{
console.log('初始化打开台衡M523体重秤端口')
- const serialport = new SerialPort({ path, baudRate }, (err: any) => {
- if (err) {
- console.log(err)
- ElMessage({
- message: '台衡M523体重秤端口打开失败！',
- type: 'error',
+ if(reconnectAttempts!==0){
+ console.log('ssss',reconnectAttempts)
+ ipcRenderer.invoke('logger', '串口重连第${reconnectAttempts}次')
+ ElMessage({
+ message: `串口重连第${reconnectAttempts}次启动`,
+ type: 'success',
+ })
+ }
+ if (reconnectAttempts >= MAX_RECONNECT_ATTEMPTS) {
+ console.error('重试次数达到上限，不再尝试重连。');
+ ipcRenderer.invoke('logger', '串口已经重连了${reconnectAttempts}次了，点击确认关闭程序，重启电脑后再试')
+ ElMessageBox.confirm(
+ `串口已经重连了${reconnectAttempts}次了，点击确认关闭程序，重启电脑后再试`,
+ 'Warning',
+ {
+ confirmButtonText: '确认',
+ cancelButtonText: '取消',
+ type: 'warning',
+ }
+ )
+ .then(() => {
+ ipcRenderer.send('winClose')
+ ipcRenderer.invoke('logger', '确认了关闭程序')
})
- console.log(err)
- }else{
- ElMessage({
- message: '台衡M523体重秤端口打开成功',
- type: 'success',
+ .catch(() => {
+ ElMessage({
+ type: 'info',
+ message: '取消操作',
+ })
})
- }
- })
- serialport.on("close",(err: any)=>{
- console.log('台衡M523体重秤端口异常端口链接断开')
- console.log(err)
- })
- // 解析分割数据流
- //ST,GS 70.4kg
- //
- //
- //
- //
- //
- // 53 54 2C 47 53 20 37 30 2E 34 6B 67 0D 0A HEX
- const parser = serialport.pipe(new DelimiterParser({ delimiter:Buffer.from([107,103,13,10]),includeDelimiter:true }))
- parser.on('data', (value: string | any[])=>{
- console.log(value.toString())
- const str=value.toString()
- const list=str.split(' ')
- console.log(list)
- if(list.length===2&&list[0].search('ST,GS')!==-1){
- const re=list[1].trim()
- const res=re.substring(0,re.length-2)
- console.log(res,'获取到的体重')
- sockteStore().setweightSockte(
- {
- deviceName:'台衡M523',
- type:"体重秤",
- result:res,
- resultTime:new Date().toString(),
- state:2
- }
- )
- }else{
- console.log('数据格式不对')
- }
- }) // all data after READY is received
+ return;
+ }
+ if (serialPort && serialPort.isOpen) {
+ reconnectAttempts=0
+ console.log('串口已打开，不再重复打开。');
+ return;
+ }
+ try {
+ const serialport = new SerialPort({ path, baudRate }, (err: any) => {
+ reconnectAttempts++
+ if (err) {
+ console.log(err)
+ ipcRenderer.invoke('logger', ' M523体重秤端口打开失败！')
+ ElMessage({
+ message: ' M523体重秤端口打开失败！',
+ type: 'error',
+ })
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ }else{
+ reconnectAttempts=0
+ ipcRenderer.invoke('logger', ' M523体重秤端口打开成功')
+ ElMessage({
+ message: ' M523体重秤端口打开成功',
+ type: 'success',
+ })
+ }
+ })
+ serialport.on("close",(err: any)=>{
+ ipcRenderer.invoke('logger', ' M523体重秤端口异常端口链接关闭')
+ console.log(' M523体重秤端口异常端口链接断开')
+ reconnectAttempts=0
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ console.log(err)
+ })
+ // 解析分割数据流
+ //ST,GS 70.4kg
+ //
+ //
+ //
+ //
+ //
+ // 53 54 2C 47 53 20 37 30 2E 34 6B 67 0D 0A HEX
+ const parser = serialport.pipe(new DelimiterParser({ delimiter:Buffer.from([107,103,13,10]),includeDelimiter:true }))
+ parser.on('data', (value: string | any[])=>{
+ console.log(value.toString())
+ const str=value.toString()
+ const list=str.split(' ')
+ console.log(list)
+ if(list.length===2&&list[0].search('ST,GS')!==-1){
+ const re=list[1].trim()
+ const res=re.substring(0,re.length-2)
+ console.log(res,'获取到的体重')
+ sockteStore().setweightSockte(
+ {
+ deviceName:'台衡M523',
+ type:"体重秤",
+ result:res,
+ resultTime:new Date().toString(),
+ state:2
+ }
+ )
+ }else{
+ console.log('数据格式不对')
+ }
+ })
+ }
+ catch (error:any) {
+ console.error('无法创建串口实例:', error.message);
+ reconnectAttempts=0
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ }
+
}
export {
diff --git a/src/samples/deviceApi/xinanguojiTZC.ts b/src/samples/deviceApi/xinanguojiTZC.ts
index 795e95c..f9923ea 100644
--- a/src/samples/deviceApi/xinanguojiTZC.ts
+++ b/src/samples/deviceApi/xinanguojiTZC.ts
@@ -1,4 +1,4 @@
-import { ElMessage, ElMessageBox } from 'element-plus'
+import { ElMessage, ElMessageBox, ElNotification } from 'element-plus'
const { SerialPort } = require('serialport')
const { DelimiterParser } = require('@serialport/parser-delimiter')
const { ReadyParser } = require('@serialport/parser-ready')
@@ -24,7 +24,7 @@
if (reconnectAttempts !== 0) {
console.log('ssss', reconnectAttempts)
ipcRenderer.invoke('logger', '串口重连第${reconnectAttempts}次')
- ElMessage({
+ ElMessage.warning({
message: `串口重连第${reconnectAttempts}次启动`,
type: 'success',
})
@@ -64,10 +64,12 @@
if (err) {
console.log(err)
ipcRenderer.invoke('logger', '新安国际体重秤端口打开失败！')
- ElMessage({
+ ElNotification.warning({
+ title: '警告',
message: '新安国际体重秤端口打开失败！',
- type: 'error',
- })
+ showClose: false,
+ duration:10000
+ })
setTimeout(() => {
initPort(path, baudRate)
}, RECONNECT_INTERVAL);
diff --git a/src/samples/deviceApi/zhiRongHehui.ts b/src/samples/deviceApi/zhiRongHehui.ts
index 52416dc..87e78ca 100644
--- a/src/samples/deviceApi/zhiRongHehui.ts
+++ b/src/samples/deviceApi/zhiRongHehui.ts
@@ -1,67 +1,189 @@
// 欧姆龙 HBP-9030 115200
-import { ElMessage } from 'element-plus'
+import { ElMessage, ElMessageBox, ElNotification } from 'element-plus'
const { SerialPort } = require('serialport')
const { DelimiterParser } = require('@serialport/parser-delimiter')
const { ReadyParser } = require('@serialport/parser-ready')
import {sockteStore} from '@/stores/sockteInfo'
+import { ipcRenderer } from 'electron'
+
+
+
+// 设置重连间隔和最大重试次数
+const RECONNECT_INTERVAL = 10000; // 重连间隔10秒
+const MAX_RECONNECT_ATTEMPTS = 10; // 最大重试次数10次
+
+let reconnectAttempts = 0; // 当前重试次数
+let serialPort:any; // 串口实例
+
const initPort=(path:String,baudRate:Number)=>{
console.log('初始化打开志荣体重秤端口')
- const serialport = new SerialPort({ path, baudRate }, (err: any) => {
- if (err) {
- console.log(err)
- ElMessage({
- message: '合肥志荣体重秤端口打开失败！',
- type: 'error',
+ if(reconnectAttempts!==0){
+ console.log('ssss',reconnectAttempts)
+ ipcRenderer.invoke('logger', `串口重连第${reconnectAttempts}次`)
+ ElMessage.warning({
+ message: `串口重连第${reconnectAttempts}次启动`,
+ type: 'success',
+ })
+ }
+ if (reconnectAttempts >= MAX_RECONNECT_ATTEMPTS) {
+ console.error('重试次数达到上限，不再尝试重连。');
+ ipcRenderer.invoke('logger', `串口已经重连了${reconnectAttempts}次了，点击确认关闭程序，重启电脑后再试`)
+ ElMessageBox.confirm(
+ `串口已经重连了${reconnectAttempts}次了，点击确认关闭程序，重启电脑后再试`,
+ 'Warning',
+ {
+ confirmButtonText: '确认',
+ cancelButtonText: '取消',
+ type: 'warning',
+ }
+ )
+ .then(() => {
+ ipcRenderer.send('winClose')
+ ipcRenderer.invoke('logger', '确认了关闭程序')
})
- console.log(err)
- }else{
- ElMessage({
- message: '合肥志荣体重秤端口打开成功',
- type: 'success',
+ .catch(() => {
+ ElMessage({
+ type: 'info',
+ message: '取消操作',
+ })
})
- }
- })
- serialport.on("close",(err: any)=>{
- console.log('志荣体重秤端口异常端口链接断开')
- console.log(err)
- })
- // 解析分割数据流
- // No:4742
- // Gross: 75.0kg
- // Tare: 0.0kg
- // Net: 75.0kg
- //
- //
- //
- //
- //
- // 20 20 20 4E 6F 3A 3535 39 38 0D 0A 4772 6F 73 73 3A 20 2020 36 31 2E 36 6B 67 0D 0A20 54 61 72 65 3A 2020 20 20 30 2E 30 6B 670D 0A 20 20 4E 65 743A 20 20 20 36 31 2E36 6B 67
- // 0D 0A 0D 0A0D 0A 0D 0A 0D 0A 0D 0A
- const parser = serialport.pipe(new DelimiterParser({ delimiter:Buffer.from([13,10,13,10,13,10,13,10,13,10,13,10]),includeDelimiter:true }))
- parser.on('data', (value: string | any[])=>{
- console.log(value.toString())
- const str=value.toString()
- const list=str.split('Net:')
- console.log(list)
- if(list.length===2){
- const re=list[1].trim()
- const res=re.substring(0,re.length-2)
- console.log(res)
- sockteStore().setweightSockte(
- {
- deviceName:'志荣T605',
- type:"体重秤",
- result:res,
- resultTime:new Date().toString(),
- state:2
- }
- )
- }else{
- console.log('数据格式不对')
- }
- }) // all data after READY is received
+ return;
+ }
+ if (serialPort && serialPort.isOpen) {
+ reconnectAttempts=0
+ console.log('串口已打开，不再重复打开。');
+ return;
+ }
+ try {
+ const serialport = new SerialPort({ path, baudRate }, (err: any) => {
+ reconnectAttempts++
+ if (err) {
+ console.log(err)
+ ipcRenderer.invoke('logger', 'hefeiz志荣体重秤端口打开失败！')
+ ElNotification.warning({
+ title: '警告',
+ message: 'hefeiz志荣体重秤端口打开失败！',
+ showClose: false,
+ duration:10000
+ })
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ }else{
+ reconnectAttempts=0
+ ipcRenderer.invoke('logger', 'hefeiz志荣体重秤端口打开成功')
+ ElMessage({
+ message: 'hefeiz志荣体重秤端口打开成功',
+ type: 'success',
+ })
+ }
+ })
+ serialport.on("close",(err: any)=>{
+ ipcRenderer.invoke('logger', 'hefeiz志荣体重秤端口异常端口链接关闭')
+ console.log('hefeiz志荣体重秤端口异常端口链接断开')
+ reconnectAttempts=0
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ console.log(err)
+ })
+ // 解析分割数据流
+ // No:4742
+ // Gross: 75.0kg
+ // Tare: 0.0kg
+ // Net: 75.0kg
+ //
+ //
+ //
+ //
+ //
+ // 20 20 20 4E 6F 3A 3535 39 38 0D 0A 4772 6F 73 73 3A 20 2020 36 31 2E 36 6B 67 0D 0A20 54 61 72 65 3A 2020 20 20 30 2E 30 6B 670D 0A 20 20 4E 65 743A 20 20 20 36 31 2E 36 6B 67
+ const parser = serialport.pipe(new DelimiterParser({ delimiter:Buffer.from([13,10,13,10,13,10,13,10,13,10,13,10]),includeDelimiter:true }))
+ parser.on('data', (value: string | any[])=>{
+ console.log(value.toString())
+ const str=value.toString()
+ const list=str.split('Net:')
+ console.log(list)
+ if(list.length===2){
+ const re=list[1].trim()
+ const res=re.substring(0,re.length-2)
+ console.log(res)
+ sockteStore().setweightSockte(
+ {
+ deviceName:'志荣T605',
+ type:"体重秤",
+ result:res,
+ resultTime:new Date().toString(),
+ state:2
+ }
+ )
+ }else{
+ console.log('数据格式不对')
+ }
+ })
+ }
+ catch (error:any) {
+ console.error('无法创建串口实例:', error.message);
+ reconnectAttempts=0
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ }
+ // const serialport = new SerialPort({ path, baudRate }, (err: any) => {
+ // if (err) {
+ // console.log(err)
+ // ElMessage({
+ // message: '合肥志荣体重秤端口打开失败！',
+ // type: 'error',
+ // })
+ // console.log(err)
+ // }else{
+ // ElMessage({
+ // message: '合肥志荣体重秤端口打开成功',
+ // type: 'success',
+ // })
+ // }
+ // })
+ // serialport.on("close",(err: any)=>{
+ // console.log('志荣体重秤端口异常端口链接断开')
+ // console.log(err)
+ // })
+ // // 解析分割数据流
+ // // No:4742
+ // // Gross: 75.0kg
+ // // Tare: 0.0kg
+ // // Net: 75.0kg
+ // //
+ // //
+ // //
+ // //
+ // //
+ // // 20 20 20 4E 6F 3A 3535 39 38 0D 0A 4772 6F 73 73 3A 20 2020 36 31 2E 36 6B 67 0D 0A20 54 61 72 65 3A 2020 20 20 30 2E 30 6B 670D 0A 20 20 4E 65 743A 20 20 20 36 31 2E36 6B 67
+ // const parser = serialport.pipe(new DelimiterParser({ delimiter:Buffer.from([13,10,13,10,13,10,13,10,13,10,13,10]),includeDelimiter:true }))
+ // parser.on('data', (value: string | any[])=>{
+ // console.log(value.toString())
+ // const str=value.toString()
+ // const list=str.split('Net:')
+ // console.log(list)
+ // if(list.length===2){
+ // const re=list[1].trim()
+ // const res=re.substring(0,re.length-2)
+ // console.log(res)
+ // sockteStore().setweightSockte(
+ // {
+ // deviceName:'志荣T605',
+ // type:"体重秤",
+ // result:res,
+ // resultTime:new Date().toString(),
+ // state:2
+ // }
+ // )
+ // }else{
+ // console.log('数据格式不对')
+ // }
+ // }) // all data after READY is received
}
export {
diff --git a/src/samples/deviceApi/zhiRongT605.ts b/src/samples/deviceApi/zhiRongT605.ts
index cf10332..320b07c 100644
--- a/src/samples/deviceApi/zhiRongT605.ts
+++ b/src/samples/deviceApi/zhiRongT605.ts
@@ -1,65 +1,187 @@
// 欧姆龙 HBP-9030 115200
-import { ElMessage } from 'element-plus'
+import { ElMessage, ElMessageBox, ElNotification } from 'element-plus'
const { SerialPort } = require('serialport')
const { DelimiterParser } = require('@serialport/parser-delimiter')
const { ReadyParser } = require('@serialport/parser-ready')
import {sockteStore} from '@/stores/sockteInfo'
+import { ipcRenderer } from 'electron'
+
+// 设置重连间隔和最大重试次数
+const RECONNECT_INTERVAL = 10000; // 重连间隔10秒
+const MAX_RECONNECT_ATTEMPTS = 10; // 最大重试次数10次
+
+let reconnectAttempts = 0; // 当前重试次数
+let serialPort:any; // 串口实例
+
+
const initPort=(path:String,baudRate:Number)=>{
console.log('初始化打开志荣体重秤端口')
- const serialport = new SerialPort({ path, baudRate }, (err: any) => {
- if (err) {
- console.log(err)
- ElMessage({
- message: '志荣体重秤端口打开失败！',
- type: 'error',
+ if(reconnectAttempts!==0){
+ console.log('ssss',reconnectAttempts)
+ ipcRenderer.invoke('logger', `串口重连第${reconnectAttempts}次`)
+ ElMessage.warning({
+ message: `串口重连第${reconnectAttempts}次启动`,
+ type: 'success',
+ })
+ }
+ if (reconnectAttempts >= MAX_RECONNECT_ATTEMPTS) {
+ console.error('重试次数达到上限，不再尝试重连。');
+ ipcRenderer.invoke('logger', `串口已经重连了${reconnectAttempts}次了，点击确认关闭程序，重启电脑后再试`)
+ ElMessageBox.confirm(
+ `串口已经重连了${reconnectAttempts}次了，点击确认关闭程序，重启电脑后再试`,
+ 'Warning',
+ {
+ confirmButtonText: '确认',
+ cancelButtonText: '取消',
+ type: 'warning',
+ }
+ )
+ .then(() => {
+ ipcRenderer.send('winClose')
+ ipcRenderer.invoke('logger', '确认了关闭程序')
})
- console.log(err)
- }else{
- ElMessage({
- message: '志荣体重秤端口打开成功',
- type: 'success',
+ .catch(() => {
+ ElMessage({
+ type: 'info',
+ message: '取消操作',
+ })
})
- }
- })
- serialport.on("close",(err: any)=>{
- console.log('志荣体重秤端口异常端口链接断开')
- console.log(err)
- })
- // 解析分割数据流
- // No:4742
- // Gross: 75.0kg
- // Tare: 0.0kg
- // Net: 75.0kg
- //
- //
- //
- //
- //
- // 20 20 20 4E6F 3A 34 37 34 31 0A47 72 6F 73 73 3A 20 20 3733 2E 37 6B 67 0A 20 5461 72 65 3A 20 20 2030 2E 30 6B 67 0A 20 204E 65 74 3A 20 20 3733 2E 37 6B 67 0A 0A0A 0A 0A
- const parser = serialport.pipe(new DelimiterParser({ delimiter:Buffer.from([10,10,10,10,10]),includeDelimiter:true }))
- parser.on('data', (value: string | any[])=>{
- console.log(value.toString())
- const str=value.toString()
- const list=str.split('Net:')
- console.log(list)
- if(list.length===2){
- const re=list[1].trim()
- const res=re.substring(0,re.length-2)
- console.log(res)
- sockteStore().setweightSockte(
- {
- deviceName:'志荣T605',
- type:"体重秤",
- result:res,
- resultTime:new Date().toString(),
- state:2
- }
- )
- }else{
- console.log('数据格式不对')
- }
- }) // all data after READY is received
+ return;
+ }
+ if (serialPort && serialPort.isOpen) {
+ reconnectAttempts=0
+ console.log('串口已打开，不再重复打开。');
+ return;
+ }
+ try {
+ const serialport = new SerialPort({ path, baudRate }, (err: any) => {
+ reconnectAttempts++
+ if (err) {
+ console.log(err)
+ ipcRenderer.invoke('logger', ' 志荣体重秤端口打开失败！')
+ ElNotification.warning({
+ title: '警告',
+ message: ' 志荣体重秤端口打开失败！',
+ showClose: false,
+ duration:10000
+ })
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ }else{
+ reconnectAttempts=0
+ ipcRenderer.invoke('logger', ' 志荣体重秤端口打开成功')
+ ElMessage({
+ message: ' 志荣体重秤端口打开成功',
+ type: 'success',
+ })
+ }
+ })
+ serialport.on("close",(err: any)=>{
+ ipcRenderer.invoke('logger', ' 志荣体重秤端口异常端口链接关闭')
+ console.log(' 志荣体重秤端口异常端口链接断开')
+ reconnectAttempts=0
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ console.log(err)
+ })
+ // 解析分割数据流
+ // No:4742
+ // Gross: 75.0kg
+ // Tare: 0.0kg
+ // Net: 75.0kg
+ //
+ //
+ //
+ //
+ //
+ // 20 20 20 4E6F 3A 34 37 34 31 0A47 72 6F 73 73 3A 20 20 3733 2E 37 6B 67 0A 20 5461 72 65 3A 20 20 2030 2E 30 6B 67 0A 20 204E 65 74 3A 20 20 3733 2E 37 6B 67 0A 0A0A 0A 0A
+ const parser = serialport.pipe(new DelimiterParser({ delimiter:Buffer.from([10,10,10,10,10]),includeDelimiter:true }))
+ parser.on('data', (value: string | any[])=>{
+ console.log(value.toString())
+ const str=value.toString()
+ const list=str.split('Net:')
+ console.log(list)
+ if(list.length===2){
+ const re=list[1].trim()
+ const res=re.substring(0,re.length-2)
+ console.log(res)
+ sockteStore().setweightSockte(
+ {
+ deviceName:'志荣T605',
+ type:"体重秤",
+ result:res,
+ resultTime:new Date().toString(),
+ state:2
+ }
+ )
+ }else{
+ console.log('数据格式不对')
+ }
+ }) // all data after READY is received
+ }
+ catch (error:any) {
+ console.error('无法创建串口实例:', error.message);
+ reconnectAttempts=0
+ setTimeout(()=>{
+ initPort(path,baudRate)
+ }, RECONNECT_INTERVAL);
+ }
+ // const serialport = new SerialPort({ path, baudRate }, (err: any) => {
+ // if (err) {
+ // console.log(err)
+ // ElMessage({
+ // message: '志荣体重秤端口打开失败！',
+ // type: 'error',
+ // })
+ // console.log(err)
+ // }else{
+ // ElMessage({
+ // message: '志荣体重秤端口打开成功',
+ // type: 'success',
+ // })
+ // }
+ // })
+ // serialport.on("close",(err: any)=>{
+ // console.log('志荣体重秤端口异常端口链接断开')
+ // console.log(err)
+ // })
+ // // 解析分割数据流
+ // // No:4742
+ // // Gross: 75.0kg
+ // // Tare: 0.0kg
+ // // Net: 75.0kg
+ // //
+ // //
+ // //
+ // //
+ // //
+ // // 20 20 20 4E6F 3A 34 37 34 31 0A47 72 6F 73 73 3A 20 20 3733 2E 37 6B 67 0A 20 5461 72 65 3A 20 20 2030 2E 30 6B 67 0A 20 204E 65 74 3A 20 20 3733 2E 37 6B 67 0A 0A0A 0A 0A
+ // const parser = serialport.pipe(new DelimiterParser({ delimiter:Buffer.from([10,10,10,10,10]),includeDelimiter:true }))
+ // parser.on('data', (value: string | any[])=>{
+ // console.log(value.toString())
+ // const str=value.toString()
+ // const list=str.split('Net:')
+ // console.log(list)
+ // if(list.length===2){
+ // const re=list[1].trim()
+ // const res=re.substring(0,re.length-2)
+ // console.log(res)
+ // sockteStore().setweightSockte(
+ // {
+ // deviceName:'志荣T605',
+ // type:"体重秤",
+ // result:res,
+ // resultTime:new Date().toString(),
+ // state:2
+ // }
+ // )
+ // }else{
+ // console.log('数据格式不对')
+ // }
+ // }) // all data after READY is received
}
export {
--
Gitblit v1.8.0