|
@@ -0,0 +1,258 @@
|
|
|
|
+package com.huimv.env.input.server;
|
|
|
|
+
|
|
|
|
+import com.alibaba.fastjson.JSONArray;
|
|
|
|
+import com.huimv.env.common.utils.RegexUtil;
|
|
|
|
+import io.netty.buffer.ByteBuf;
|
|
|
|
+import io.netty.buffer.Unpooled;
|
|
|
|
+import io.netty.channel.ChannelHandler;
|
|
|
|
+import io.netty.channel.ChannelHandlerContext;
|
|
|
|
+import io.netty.channel.ChannelInboundHandlerAdapter;
|
|
|
|
+import io.netty.util.CharsetUtil;
|
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
+import org.springframework.beans.factory.annotation.Value;
|
|
|
|
+import org.springframework.stereotype.Component;
|
|
|
|
+
|
|
|
|
+import java.io.BufferedWriter;
|
|
|
|
+import java.io.File;
|
|
|
|
+import java.io.FileWriter;
|
|
|
|
+import java.io.IOException;
|
|
|
|
+import java.text.ParseException;
|
|
|
|
+import java.util.HashMap;
|
|
|
|
+import java.util.Map;
|
|
|
|
+import java.util.regex.Matcher;
|
|
|
|
+import java.util.regex.Pattern;
|
|
|
|
+
|
|
|
|
+/**
|
|
|
|
+ * @Project : huimv.shiwan
|
|
|
|
+ * @Package : com.huimv.biosafety.uface.controller
|
|
|
|
+ * @Description : TODO
|
|
|
|
+ * @Version : 1.0
|
|
|
|
+ * @Author : ZhuoNing
|
|
|
|
+ * @Create : 2020-12-25
|
|
|
|
+ **/
|
|
|
|
+@ChannelHandler.Sharable
|
|
|
|
+@Component
|
|
|
|
+@Slf4j
|
|
|
|
+public class EnvInputServerHandler extends ChannelInboundHandlerAdapter {
|
|
|
|
+ @Autowired
|
|
|
|
+ private RegexUtil regexUtil;
|
|
|
|
+ private StringBuilder askTextSb = null;
|
|
|
|
+ private int num = 0;
|
|
|
|
+
|
|
|
|
+ //
|
|
|
|
+ public void appendClientAsk(String text){
|
|
|
|
+ if(this.askTextSb == null){
|
|
|
|
+ askTextSb = new StringBuilder();
|
|
|
|
+ }
|
|
|
|
+ askTextSb.append(text);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
|
|
|
|
+ ByteBuf data = (ByteBuf) msg;
|
|
|
|
+ String clientAskText = data.toString(CharsetUtil.UTF_8);
|
|
|
|
+// System.out.println((++num)+"次, 客户端消息clientAskText>>"+clientAskText);
|
|
|
|
+ //保存实例内的客户端请求
|
|
|
|
+ appendClientAsk(clientAskText);
|
|
|
|
+ //临时写入耳标数据到文件
|
|
|
|
+// writeTxt(clientAskText,"all");
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
|
|
|
|
+// ctx.writeAndFlush("111");
|
|
|
|
+// System.out.println("EchoServerHandle channelReadComplete");
|
|
|
|
+ if(askTextSb.toString().indexOf("end") != -1){
|
|
|
|
+// System.out.println("askTextSb.内容()>>"+askTextSb.toString());
|
|
|
|
+// System.out.println("askTextSb.内容长度>>"+askTextSb.length());
|
|
|
|
+// System.out.println("输入完成.");
|
|
|
|
+ // 处理客户端消息
|
|
|
|
+ handleClientEartagMessage(askTextSb.toString(),ctx);
|
|
|
|
+ //清空重置;
|
|
|
|
+ askTextSb.delete(0,askTextSb.length());
|
|
|
|
+ num = 0;
|
|
|
|
+// System.out.println("清空sb实例. 长度>>"+askTextSb.length());
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
|
|
|
|
+// System.out.println("cause.getMessage()>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>"+cause.getMessage());
|
|
|
|
+ if(cause.getMessage().indexOf("Connection reset") != -1){
|
|
|
|
+ log.info("相关采集器设备正在重启:"+cause.toString());
|
|
|
|
+ }
|
|
|
|
+// cause.printStackTrace();
|
|
|
|
+ ctx.close();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * @Method : handleClientMessage
|
|
|
|
+ * @Description : 处理请求小心
|
|
|
|
+ * @Params : [clientAskText, ctx]
|
|
|
|
+ * @Return : void
|
|
|
|
+ *
|
|
|
|
+ * @Author : ZhuoNing
|
|
|
|
+ * @Date : 2022/3/28
|
|
|
|
+ * @Time : 17:36
|
|
|
|
+ */
|
|
|
|
+ private void handleClientEartagMessage(String clientAskText,ChannelHandlerContext ctx) throws ParseException, IOException {
|
|
|
|
+ clientAskText = clientAskText.replaceAll("\r","").replaceAll("\n","");
|
|
|
|
+
|
|
|
|
+ //{}
|
|
|
|
+ int countPlus = regexUtil.countPlus(clientAskText);
|
|
|
|
+ if (countPlus < 4) {
|
|
|
|
+ System.out.println("当前数据为不完整数据,故丢弃.>>" + clientAskText);
|
|
|
|
+ } else {
|
|
|
|
+ //--处理客户端请求数据
|
|
|
|
+ //{拆分粘包数据}
|
|
|
|
+ JSONArray askJa = getPerData(clientAskText);
|
|
|
|
+ for (int a = 0; a < askJa.size(); a++) {
|
|
|
|
+ String askText = askJa.getString(a);
|
|
|
|
+// if (dataInputFlow == 1) {
|
|
|
|
+// //{处理请求内容}
|
|
|
|
+// handleAskText(askText, ctx);
|
|
|
|
+// } else {
|
|
|
|
+ //{处理请求内容2}
|
|
|
|
+ handleAskText2(askText, ctx);
|
|
|
|
+// }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * @Method : handleAskText2
|
|
|
|
+ * @Description :
|
|
|
|
+ * @Params : [askText, ctx]
|
|
|
|
+ * @Return : void
|
|
|
|
+ * @Author : ZhuoNing
|
|
|
|
+ * @Date : 2022/3/23
|
|
|
|
+ * @Time : 18:08
|
|
|
|
+ */
|
|
|
|
+ private void handleAskText2(String askText, ChannelHandlerContext ctx) throws ParseException, IOException {
|
|
|
|
+ String[] dataArray = askText.split("\\+");
|
|
|
|
+ String cmdHeader = dataArray[0];
|
|
|
|
+ //芯片id/设备编码
|
|
|
|
+ String idCode = dataArray[1];
|
|
|
|
+ String cmd = dataArray[2];
|
|
|
|
+ Map map = new HashMap();
|
|
|
|
+ map.put("askText", askText);
|
|
|
|
+ if (cmdHeader.trim().equalsIgnoreCase("hm")) {
|
|
|
|
+ //采集器应答数据
|
|
|
|
+ if (cmd.trim().equalsIgnoreCase("0")) {
|
|
|
|
+ //不需要处理
|
|
|
|
+ System.out.println("==>命令0");
|
|
|
|
+ } else if (cmd.trim().equalsIgnoreCase("1")) {
|
|
|
|
+// System.out.println("==>命令1请求 askText>>" + askText.trim());
|
|
|
|
+// //处理获取设备编码命令
|
|
|
|
+// //{读取设备编码}
|
|
|
|
+// String deviceCode = dataService.getDeviceCodeByChipId(idCode);
|
|
|
|
+// log.info("获取设备编码结果,芯片id>>" + idCode + " ,deviceCode>>" + deviceCode);
|
|
|
|
+// if (deviceCode != null) {
|
|
|
|
+// String answer = "hm+1+0+" + deviceCode + "+123+8+end";
|
|
|
|
+// log.info(">>命令1设备编码-应答数据>>" + answer);
|
|
|
|
+// ctx.writeAndFlush(Unpooled.copiedBuffer(answer.getBytes()));
|
|
|
|
+// } else {
|
|
|
|
+// log.error("检测到未注册的采集器设备,已舍弃请求.");
|
|
|
|
+// }
|
|
|
|
+ } else if (cmd.trim().equalsIgnoreCase("2")) {
|
|
|
|
+// System.out.println("==>命令2获取服务器时间请求 askText>>" + askText);
|
|
|
|
+// if (dataService.isEffectiveDevice(idCode)) {
|
|
|
|
+// //处理服务器时间命令
|
|
|
|
+// String answer = "hm+2+" + dateUtil.getNowText() + "+4+end";
|
|
|
|
+// log.info(">>命令2服务器时间-应答数据>>" + answer);
|
|
|
|
+// ctx.writeAndFlush(Unpooled.copiedBuffer(answer.getBytes()));
|
|
|
|
+// }else {
|
|
|
|
+// System.out.println("##获取服务器时间-无效设备编码 idCode=" + idCode);
|
|
|
|
+// }
|
|
|
|
+ } else if (cmd.trim().equalsIgnoreCase("3")) {
|
|
|
|
+// System.out.println("==>命令3心跳包请求 askText>>" + askText);
|
|
|
|
+// //处理心跳包命令
|
|
|
|
+// //{设备心跳应答}
|
|
|
|
+// if (dataService.isEffectiveDevice(idCode)) {
|
|
|
|
+// String answer = "hm+3+6+end";
|
|
|
|
+// log.info(">>命令3心跳包-应答数据>>" + answer);
|
|
|
|
+// ctx.writeAndFlush(Unpooled.copiedBuffer(answer.getBytes()));
|
|
|
|
+//
|
|
|
|
+// //{发送到设备处理消息队列}
|
|
|
|
+// dataService.sendDeviceMQ(map);
|
|
|
|
+// log.info(">>发送设备心跳数据消息到MQ."+map);
|
|
|
|
+// } else {
|
|
|
|
+// System.out.println("##心跳包-无效设备编码(" + idCode+"),请求拒绝。");
|
|
|
|
+// }
|
|
|
|
+ } else if (cmd.trim().equalsIgnoreCase("4")) {
|
|
|
|
+ System.out.println("==>命令4环境温度请求 askText>>" + askText);
|
|
|
|
+ //处理设备环境温度命令
|
|
|
|
+ //{设备环境温度应答}
|
|
|
|
+// if (dataService.isEffectiveDevice(idCode)) {
|
|
|
|
+// String answer = "hm+4+7+end";
|
|
|
|
+// log.info(">>命令4环境温度-应答数据>>" + answer);
|
|
|
|
+// ctx.writeAndFlush(Unpooled.copiedBuffer(answer.getBytes()));
|
|
|
|
+//
|
|
|
|
+// //{发送到设备处理消息队列}
|
|
|
|
+// dataService.sendDeviceMQ(map);
|
|
|
|
+// log.info(">>发送设备环境温度数据消息到MQ."+map);
|
|
|
|
+// } else {
|
|
|
|
+// System.out.println("##环境温度-无效设备编码(" + idCode+"),请求拒绝。");
|
|
|
|
+// }
|
|
|
|
+ } else {
|
|
|
|
+ System.out.println("==>未知命令");
|
|
|
|
+ log.error(">>当前数据为非法数据>>" + askText);
|
|
|
|
+ }
|
|
|
|
+ } else if (cmdHeader.trim().equalsIgnoreCase("zj")) {
|
|
|
|
+ System.out.println("==>耳标命令请求 askText>>"+askText);
|
|
|
|
+ //测试-临时写入耳标数据到文件
|
|
|
|
+ if(askText.trim().indexOf("330110002000002") != -1){
|
|
|
|
+// writeTxt(askText,"input");
|
|
|
|
+ }
|
|
|
|
+ //耳标应答数据(不需要应答)
|
|
|
|
+// if (checkValidEarmark(cmd)) {
|
|
|
|
+// log.error(">>舍弃掉未配置耳标号的耳标," + askText + "");
|
|
|
|
+// } else {
|
|
|
|
+ //{检查设备是否在处于工作状态或待机状态}
|
|
|
|
+// if (dataService.isWorkStatusDevice(idCode)) {
|
|
|
|
+// if (dataService.isEffectiveDevice(idCode)) {
|
|
|
|
+// //{发送到耳标处理消息队列}
|
|
|
|
+// dataService.sendEartagMQ(map);
|
|
|
|
+// log.info(">>发送耳标数据消息到MQ."+map);
|
|
|
|
+// }else{
|
|
|
|
+// System.out.println("无效设备编码 idCode="+idCode);
|
|
|
|
+// }
|
|
|
|
+// }
|
|
|
|
+ } else {
|
|
|
|
+ System.out.println("==>未知命令");
|
|
|
|
+ log.error("##当前请求数据为非法数据>>" + askText);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ //检查无效耳标
|
|
|
|
+ public boolean checkValidEarmark(String earmark) {
|
|
|
|
+ if (earmark.trim().equalsIgnoreCase("ffffffffffffffff") || earmark.trim().equalsIgnoreCase("0000000000000000")) {
|
|
|
|
+ return true;
|
|
|
|
+ } else {
|
|
|
|
+ return false;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ //拆分粘包数据
|
|
|
|
+ public JSONArray getPerData(String text) {
|
|
|
|
+ String key = "end";
|
|
|
|
+ Pattern pattern = Pattern.compile(key);
|
|
|
|
+ Matcher matcher = pattern.matcher(text);
|
|
|
|
+ int count = 0;
|
|
|
|
+ while (matcher.find()) {
|
|
|
|
+ count++;
|
|
|
|
+ }
|
|
|
|
+ JSONArray dataJa = new JSONArray();
|
|
|
|
+ if (count == 1) {
|
|
|
|
+ dataJa.add(text);
|
|
|
|
+ } else {
|
|
|
|
+ for (int a = 0; a < count; a++) {
|
|
|
|
+ int p1 = text.indexOf("end");
|
|
|
|
+ dataJa.add(text.substring(0, p1 + 3));
|
|
|
|
+ text = text.substring(p1 + 3, text.length());
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ return dataJa;
|
|
|
|
+ }
|
|
|
|
+}
|