From 83f08194fb16c5feea1b05d682120fe76d599775 Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Fri, 05 Mar 2021 17:45:41 +0800
Subject: [PATCH] 体温数据接口
---
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyTcpServer/TcpServerHandler.java | 34 ++++++++++------------------------
1 files changed, 10 insertions(+), 24 deletions(-)
diff --git a/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyTcpServer/TcpServerHandler.java b/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyTcpServer/TcpServerHandler.java
index 7d113a5..f12c77c 100644
--- a/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyTcpServer/TcpServerHandler.java
+++ b/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyTcpServer/TcpServerHandler.java
@@ -7,7 +7,7 @@
import org.springblade.jfpt.alarm.service.IAlarmService;
import org.springblade.jfpt.equipment.service.IEquipmentService;
import org.springblade.jfpt.nettyServer.NettyConfig;
-import org.springblade.jfpt.nettyUdpServer.service.AnimalHeatService;
+import org.springblade.jfpt.animalheat.service.AnimalHeatService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
@@ -15,26 +15,6 @@
@Component
public class TcpServerHandler extends ChannelInboundHandlerAdapter {
-
- private String reg_LA ="LA[d]{8}[d|A-F]{12}[d|A-F]{8}[d|A-Z]{2}[d|A-F]{4}[x2A][d|A-F]{6}[#@]";
- private String reg_LB = "LB[\\d|A-F]{12}[\\x2A].*[#@]";
- private String reg_LB2 = "LB[\\d|A-F]{6}[\\x2A].*[#@]";
- private String reg_LD = "LD[d]{8}[d|A-F]{12}:[A-Z]{4}[\\x2A].*[#@]";
-
-
- private ConcurrentHashMap<String, Channel> sessionChannelMap = new ConcurrentHashMap<String, Channel>();
-
- @Autowired
- private org.springblade.jfpt.catalog.service.catalogService catalogService;
-
- @Autowired
- private org.springblade.jfpt.Netty.service.nettyService nettyService;
-
- @Autowired
- private IEquipmentService equipmentService;
-
- @Autowired
- private IAlarmService alarmService;
private static TcpServerHandler tcpServerHandler;
@@ -96,9 +76,15 @@
String body = new String(req, "UTF-8");
String content = body;
System.out.println("接收客户端数据:" + body);
- //插入数据
- tcpServerHandler.animalHeatService.save(body);
-
+ System.out.println("content.length() = " + content.length());
+ //获取字符串的长度
+ int length = content.length();
+ //当字符串长度大于200时，采集体温数据，小于则采集报警数据
+ //只有数据长度大于300时，采集体温数据 200-300 之间为心跳数据，当前不采集
+ if (length>250){
+ //插入数据
+ tcpServerHandler.animalHeatService.save(body);
+ }
}
--
Gitblit v1.9.3