| | |
| | | import io.netty.channel.SimpleChannelInboundHandler; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.springframework.beans.BeanUtils; |
| | | |
| | | import javax.xml.bind.DatatypeConverter; |
| | | import java.net.InetSocketAddress; |
| | |
| | | // log.info("有效负载大小(转整型):" + payloadSizeToDecimal); |
| | | //endregion |
| | | List<ArdAlarmRadar> radarAlarmInfos = new ArrayList<>(); |
| | | List<ArdAlarmRadar> radarFollowInfos = new ArrayList<>(); |
| | | ArdAlarmRadar radarFollowInfo = null; |
| | | //抽油机状态雷达推送集合 |
| | | List<ArdAlarmRadar> well = new ArrayList<>(); |
| | | String alarmTime = ""; |
| | |
| | | ardAlarmRadar.setLatitude(alarmXY[1]); |
| | | ardAlarmRadar.setAlarmType(alarmType); |
| | | radarAlarmInfos.add(ardAlarmRadar); |
| | | int bit1 = (cStat[0]>>1) & 0x1;; |
| | | int bit1 = (cStat[0] >> 1) & 0x1; |
| | | //目标的B1=1 锁定 |
| | | if(bit1==1) { |
| | | //将锁定目标放入锁定list |
| | | radarFollowInfos.add(ardAlarmRadar); |
| | | radarFollowInfo = ardAlarmRadar; |
| | | //将追踪锁定的报警对象属性复制给radarFollowInfo对象 |
| | | //BeanUtils.copyProperties(ardAlarmRadar, radarFollowInfo); |
| | | } |
| | | } |
| | | //endregion |
| | |
| | | radarAlarmData.setAlarmTime(alarmTime); |
| | | radarAlarmData.setArdAlarmRadars(radarAlarmInfos); |
| | | MqttProducer.publish(2, false, "radar", JSON.toJSONString(radarAlarmData)); |
| | | if(radarFollowInfos.size()>0) { |
| | | radarAlarmData.setArdFollowRadars(radarFollowInfos); |
| | | MqttProducer.publish(2, false, "radarFollowGuide", JSON.toJSONString(radarAlarmData)); |
| | | if (radarFollowInfo != null) { |
| | | //当前雷达扫描存在引导跟踪数据,只保留最后一次锁定的数据 |
| | | MqttProducer.publish(2, false, "radarFollowGuide", JSON.toJSONString(radarFollowInfo)); |
| | | } |
| | | //抽油机状态MQTT队列 |
| | | radarAlarmData.setArdAlarmRadars(well); |