~zhangnaisong/ruoyi-api-alarm.git

			@@ -1,24 +1,15 @@
			package com.ard.utils.tcp;

			/**
			* @Description:
			* @ClassName: ClientHandler
			* @Author: 刘苏义
			* @Date: 2023年07月05日13:13
			* @Version: 1.0
			**/

			import com.alibaba.fastjson2.JSON;
			import com.ard.alarm.radar.domain.ArdAlarmRadar;
			import com.ard.alarm.radar.domain.ArdEquipRadar;
			import com.ard.alarm.radar.domain.RadarAlarmData;
			import com.ard.utils.ByteUtils;
			import com.ard.utils.GisUtils;
			import com.ard.utils.other.ByteUtils;
			import com.ard.utils.other.GisUtils;
			import com.ard.utils.mqtt.MqttConsumer;
			import io.netty.buffer.ByteBuf;
			import io.netty.channel.ChannelHandlerContext;
			import io.netty.channel.ChannelId;
			import io.netty.channel.ChannelInboundHandlerAdapter;
			import io.netty.channel.SimpleChannelInboundHandler;
			import lombok.extern.slf4j.Slf4j;
			import org.apache.commons.lang3.StringUtils;
			@@ -33,10 +24,13 @@
			import java.util.concurrent.TimeUnit;

			/**
			* 客户端处理器
			*
			* @author lijiamin
			*/
			* @Description: 客户端处理器
			* @ClassName: ClientHandler
			* @Author: 刘苏义
			* @Date: 2023年07月05日13:13
			* @Version: 1.0
			**/

			@Slf4j(topic = "netty")
			public class ClientHandler extends SimpleChannelInboundHandler<ByteBuf> {
			private ChannelHandlerContext context;
			@@ -151,7 +145,7 @@
			byte[] heart = ByteUtils.appendArrays(header, payload, payloadCrc32, footer);
			// byte[] heart = {0x01, 0x02, 0x01, 0x10, 0x00, 0x00, 0x00, (byte) 0x83, (byte) 0x88, 0x5d, 0x71, 0x01, 0x02, 0x00};
			String hexString = DatatypeConverter.printHexBinary(heart);
			log.info("发送心跳:" + hexString);
			// log.debug("发送心跳:" + hexString);
			message.writeBytes(heart);
			context.writeAndFlush(message);

			@@ -177,12 +171,13 @@
			String radarName = ardEquipRadarbyte.getName();
			Double radarLongitude = ardEquipRadarbyte.getLongitude();
			Double radarLagitude = ardEquipRadarbyte.getLatitude();
			Double radarAltitude = ardEquipRadarbyte.getAltitude();
			//region crc校验-目前仅用于显示校验结果
			Boolean crc32Check = MessageParsing.CRC32Check(data);
			if (!crc32Check) {
			log.info("CRC32校验不通过");
			log.debug("CRC32校验不通过");
			} else {
			log.info("CRC32校验通过");
			log.debug("CRC32校验通过");
			}
			//endregion
			//log.info("原始数据:" + DatatypeConverter.printHexBinary(data));
			@@ -216,7 +211,7 @@
			if (targetNum == 0) {
			return;
			}
			log.info("目标总点数(转整型):" + targetNum);
			log.debug("目标总点数(转整型):" + targetNum);

			//解析NET_TARGET_UNIT(64是NET_TARGET_HEAD的字节数)
			int uintSize = (payloadSizeToDecimal - 64) / targetNum;
			@@ -229,13 +224,13 @@
			// log.info("目标ID:" + DatatypeConverter.printHexBinary(cmdId));
			dwID = ByteUtils.toLittleEndian(dwID);
			int id = ByteUtils.bytesToDecimal(dwID);

			// log.info("目标ID号：" + id);

			byte[] iDistance = Arrays.copyOfRange(data, index + 8, index + 12);
			iDistance = ByteUtils.toLittleEndian(iDistance);
			Double Distance = ByteUtils.bytesToDouble(iDistance);
			// log.info("目标当前距离(m):" + Distance);
			double Distance = ByteUtils.bytesToDecimal(iDistance);
			log.debug("目标当前直线距离(m):" + Distance);

			//region 不需要的字段
			// byte[] dwGSum = Arrays.copyOfRange(data, index + 4, index + 8);
			// dwGSum = toLittleEndian(dwGSum);
			@@ -306,10 +301,16 @@
			byte[] afTy = Arrays.copyOfRange(data, index + 112, index + 116);
			afTy = ByteUtils.toLittleEndian(afTy);
			float fTy = ByteUtils.bytesToFloat(afTy);
			// log.info("垂直角度:" + fTy);
			Double[] radarXY = {radarLagitude, radarLagitude};
			log.debug("垂直角度:" + fTy);
			// 将角度转换为弧度
			double thetaRadians = Math.toRadians(fTy+90);
			// 使用正弦函数计算对边长度
			Distance = Math.sin(thetaRadians) * Distance;
			log.debug("目标投影距离(m):" + Distance);

			Double[] radarXY = {radarLongitude, radarLagitude};
			Double[] alarmXY = GisUtils.CalculateCoordinates(radarXY, Distance, (double) fTx);
			// log.info("报警信息：" + "【id】" + id + "【name】" + alarmPointName + "【alarmType】" + alarmType + "【alarmTime】" + alarmTime + "【distance】" + Distance + "【P】" + fTx + "【T】" + fTy + "【X】" + alarmXY[0] + "【Y】" + alarmXY[1]);
			log.debug("报警信息：" + "【id】" + id + "【name】" + alarmPointName + "【alarmType】" + alarmType + "【alarmTime】" + alarmTime + "【distance】" + Distance + "【P】" + fTx + "【T】" + fTy + "【X】" + alarmXY[0] + "【Y】" + alarmXY[1]);
			ArdAlarmRadar ardAlarmRadar = new ArdAlarmRadar();
			ardAlarmRadar.setTargetId(id);
			ardAlarmRadar.setName(alarmPointName);
			@@ -335,7 +336,7 @@
			byte[] wTargetNum = Arrays.copyOfRange(data, 8, 10);
			wTargetNum = ByteUtils.toLittleEndian(wTargetNum);
			targetNum = ByteUtils.bytesToDecimal(wTargetNum);
			log.info("目标总点数(转整型):" + targetNum);
			log.debug("目标总点数(转整型):" + targetNum);
			if (targetNum == 0) {
			return;
			}
			@@ -363,16 +364,16 @@
			byte[] fTx = Arrays.copyOfRange(data, index + 12, index + 16);
			fTx = ByteUtils.toLittleEndian(fTx);
			float fTxAngle = ByteUtils.bytesToFloat(fTx);
			//log.info("p角度:" + fTxAngle);
			log.debug("p角度:" + fTxAngle);
			byte[] fTy = Arrays.copyOfRange(data, index + 16, index + 20);
			fTy = ByteUtils.toLittleEndian(fTy);
			float fTyAngle = ByteUtils.bytesToFloat(fTy);
			//log.info("t角度:" + fTyAngle);
			log.debug("t角度:" + fTyAngle);

			byte[] sAreaNo = Arrays.copyOfRange(data, index + 20, index + 22);
			sAreaNo = ByteUtils.toLittleEndian(sAreaNo);
			int AreaNo = ByteUtils.bytesToDecimal(sAreaNo);
			//log.info("目标归属的告警区域号:" + AreaNo);
			log.debug("目标归属的告警区域号:" + AreaNo);

			byte[] cGrp = Arrays.copyOfRange(data, index + 22, index + 23);
			cGrp = ByteUtils.toLittleEndian(cGrp);
			@@ -399,7 +400,7 @@
			//log.info("所属告警区域名称:" + DatatypeConverter.printHexBinary(szName));
			String alarmPointName = ByteUtils.bytesToStringZh(szName);
			// log.info("所属告警区域名称:" + alarmPointName);
			//log.info("报警信息：" + "【id】" + id + "【name】" + alarmPointName + "【alarmType】" + alarmType + "【alarmTime】" + alarmTime);
			log.debug("报警信息：" + "【id】" + id + "【name】" + alarmPointName + "【alarmType】" + alarmType + "【alarmTime】" + alarmTime);
			ArdAlarmRadar ardAlarmRadar = new ArdAlarmRadar();
			ardAlarmRadar.setTargetId(id);
			ardAlarmRadar.setName(alarmPointName);