分支自 ard/ruoyi-api-alarm
src/main/java/com/ard/utils/tcp/ClientHandler.java
@@ -188,7 +188,8 @@ byte[] type = Arrays.copyOfRange(data, 0, 1);//命令类型 // log.info("命令类型:" + DatatypeConverter.printHexBinary(type)); byte[] cmdId = Arrays.copyOfRange(data, 1, 2);//命令ID // log.info("命令ID:" + DatatypeConverter.printHexBinary(cmdId)); String cmdIdStr=DatatypeConverter.printHexBinary(cmdId); //log.info("命令ID:" + DatatypeConverter.printHexBinary(cmdId)); byte[] payloadSize = Arrays.copyOfRange(data, 2, 4);//有效负载大小 payloadSize = toLittleEndian(payloadSize); //log.info("payloadSize:" + DatatypeConverter.printHexBinary(payloadSize)); @@ -196,11 +197,12 @@ // log.info("有效负载大小(转整型):" + payloadSizeToDecimal); //endregion List<ArdAlarmRadar> radarAlarmInfos = new ArrayList<>(); ArdAlarmRadar radarFollowInfo = null; List<ArdAlarmRadar> radarFollowInfos = new ArrayList<>(); //抽油机状态雷达推送集合 List<ArdAlarmRadar> well = new ArrayList<>(); String alarmTime = ""; Integer targetNum = 0; log.debug("处理雷达"+radarName+"数据-->命令ID:"+cmdIdStr); //雷达移动防火报警 if (Arrays.equals(cmdId, new byte[]{0x01})) { //region 告警信息反馈 @@ -217,7 +219,7 @@ if (targetNum == 0) { return; } log.debug("目标总点数(转整型):" + targetNum); //log.debug("目标总点数(转整型):" + targetNum); //解析NET_TARGET_UNIT(64是NET_TARGET_HEAD的字节数) int uintSize = (payloadSizeToDecimal - 64) / targetNum; @@ -229,13 +231,13 @@ byte[] dwID = Arrays.copyOfRange(data, index, index + 4); // log.info("目标ID:" + DatatypeConverter.printHexBinary(cmdId)); dwID = toLittleEndian(dwID); int id = ByteUtils.bytesToDecimal(dwID); // log.info("目标ID号：" + id); int targetId = ByteUtils.bytesToDecimal(dwID); // log.info("目标ID号：" + targetId); byte[] iDistance = Arrays.copyOfRange(data, index + 8, index + 12); iDistance = toLittleEndian(iDistance); double Distance = ByteUtils.bytesToDecimal(iDistance); log.debug("目标当前直线距离(m):" + Distance); //log.debug("目标当前直线距离(m):" + Distance); //region 不需要的字段 // byte[] dwGSum = Arrays.copyOfRange(data, index + 4, index + 8); @@ -304,18 +306,22 @@ byte[] afTy = Arrays.copyOfRange(data, index + 112, index + 116); afTy = toLittleEndian(afTy); float fTy = ByteUtils.bytesToFloat(afTy); log.debug("垂直角度:" + fTy); //log.debug("垂直角度:" + fTy); // 将角度转换为弧度 double thetaRadians = Math.toRadians(fTy + 90); // 使用正弦函数计算对边长度 Distance = Math.sin(thetaRadians) * Distance; log.debug("目标投影距离(m):" + Distance); if(Distance<0) { continue;//过滤距离小于0的脏数据 } //log.debug("目标投影距离(m):" + Distance); Double[] radarXY = {radarLongitude, radarLagitude}; Double[] alarmXY = GisUtils.CalculateCoordinates(radarXY, Distance, (double) fTx); log.debug("报警信息：" + "【id】" + id + "【name】" + alarmPointName + "【alarmType】" + alarmType + "【alarmTime】" + alarmTime + "【distance】" + Distance + "【P】" + fTx + "【T】" + fTy + "【X】" + alarmXY[0] + "【Y】" + alarmXY[1]); log.debug("报警信息：" + "【radarName】" + radarName + "【targetId】"+ targetId + "【alarmType】" + alarmType + "【alarmTime】" + alarmTime + "【name】" + alarmPointName+"【Distance】"+Distance); ArdAlarmRadar ardAlarmRadar = new ArdAlarmRadar(); ardAlarmRadar.setTargetId(id); ardAlarmRadar.setTargetId(targetId); ardAlarmRadar.setName(alarmPointName); ardAlarmRadar.setLongitude(alarmXY[0]); ardAlarmRadar.setLatitude(alarmXY[1]); @@ -324,9 +330,7 @@ int bit1 = (cStat[0] >> 1) & 0x1; //目标的B1=1 锁定 if (bit1 == 1) { radarFollowInfo = ardAlarmRadar; //将追踪锁定的报警对象属性复制给radarFollowInfo对象 //BeanUtils.copyProperties(ardAlarmRadar, radarFollowInfo); radarFollowInfos.add(ardAlarmRadar); } } //endregion @@ -342,9 +346,10 @@ radarAlarmData.setAlarmTime(alarmTime); radarAlarmData.setArdAlarmRadars(radarAlarmInfos); MqttProducer.publish(2, false, "radar", JSON.toJSONString(radarAlarmData)); if (radarFollowInfo != null) { if (radarFollowInfos.size() >0) { radarAlarmData.setArdFollowRadars(radarFollowInfos); //当前雷达扫描存在引导跟踪数据，只保留最后一次锁定的数据 MqttProducer.publish(2, false, "radarFollowGuide", JSON.toJSONString(radarFollowInfo)); MqttProducer.publish(2, false, "radarFollowGuide", JSON.toJSONString(radarAlarmData)); } //抽油机状态MQTT队列 radarAlarmData.setArdAlarmRadars(well); @@ -367,7 +372,7 @@ byte[] wTargetNum = Arrays.copyOfRange(data, 8, 10); wTargetNum = toLittleEndian(wTargetNum); targetNum = ByteUtils.bytesToDecimal(wTargetNum); log.debug("目标总点数(转整型):" + targetNum); //log.debug("目标总点数(转整型):" + targetNum); if (targetNum == 0) { return; } @@ -379,8 +384,8 @@ byte[] dwID = Arrays.copyOfRange(data, index, index + 4); //log.info("目标ID:" + DatatypeConverter.printHexBinary(dwID)); dwID = toLittleEndian(dwID); int id = ByteUtils.bytesToDecimal(dwID); //log.info("目标ID号：" + id); int targetId = ByteUtils.bytesToDecimal(dwID); //log.info("目标ID号：" + targetId); //region 不需要的字段 byte[] iTw = Arrays.copyOfRange(data, index + 4, index + 8); iTw = toLittleEndian(iTw); @@ -395,16 +400,16 @@ byte[] fTx = Arrays.copyOfRange(data, index + 12, index + 16); fTx = toLittleEndian(fTx); float fTxAngle = ByteUtils.bytesToFloat(fTx); log.debug("p角度:" + fTxAngle); //log.debug("p角度:" + fTxAngle); byte[] fTy = Arrays.copyOfRange(data, index + 16, index + 20); fTy = toLittleEndian(fTy); float fTyAngle = ByteUtils.bytesToFloat(fTy); log.debug("t角度:" + fTyAngle); //log.debug("t角度:" + fTyAngle); byte[] sAreaNo = Arrays.copyOfRange(data, index + 20, index + 22); sAreaNo = toLittleEndian(sAreaNo); int AreaNo = ByteUtils.bytesToDecimal(sAreaNo); log.debug("目标归属的告警区域号:" + AreaNo); //log.debug("目标归属的告警区域号:" + AreaNo); byte[] cGrp = Arrays.copyOfRange(data, index + 22, index + 23); cGrp = toLittleEndian(cGrp); @@ -428,9 +433,9 @@ //log.info("所属告警区域名称:" + DatatypeConverter.printHexBinary(szName)); String alarmPointName = ByteUtils.bytesToStringZh(szName); // log.info("所属告警区域名称:" + alarmPointName); log.debug("报警信息：" + "【id】" + id + "【name】" + alarmPointName + "【alarmType】" + alarmType + "【alarmTime】" + alarmTime); log.debug("报警信息："+ "【radarName】" + radarName + "【targetId】" + targetId + "【name】" + alarmPointName + "【alarmType】" + alarmType + "【alarmTime】" + alarmTime); ArdAlarmRadar ardAlarmRadar = new ArdAlarmRadar(); ardAlarmRadar.setTargetId(id); ardAlarmRadar.setTargetId(targetId); ardAlarmRadar.setName(alarmPointName); ardAlarmRadar.setAlarmType(alarmType); radarAlarmInfos.add(ardAlarmRadar); @@ -441,9 +446,9 @@ //抽油机状态集合中装入数据 byte[] szName = Arrays.copyOfRange(data, index + 32, index + 64); String alarmPointName = ByteUtils.bytesToStringZh(szName); log.debug("抽油机状态报警信息：" + "【id】" + id + "【name】" + alarmPointName + "【alarmType】" + wellType + "【alarmTime】" + alarmTime); //log.debug("状态信息：" + "【radarName】" + radarName + "【targetId】" + targetId + "【alarmTime】" + alarmTime + "【name】" + alarmPointName + "【alarmState】" + wellType); ArdAlarmRadar wellAlarm = new ArdAlarmRadar(); wellAlarm.setTargetId(id); wellAlarm.setTargetId(targetId); wellAlarm.setName(alarmPointName); wellAlarm.setAlarmType(wellType); well.add(wellAlarm);
