| | |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.io.File; |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | |
| | | import static com.ruoyi.utils.tools.ArdTool.writeStringToFile; |
| | | |
| | | |
| | | /** |
| | |
| | | String alarmpointName = ardAlarmRadar.getName();//兴趣点名称 |
| | | ArdAlarmpointsWell well = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(alarmpointName); |
| | | if (well == null) { |
| | | return; |
| | | String path=System.getProperty("user.dir") + File.separator +"noExistWell.txt"; |
| | | writeStringToFile(alarmpointName,path); |
| | | continue; |
| | | } |
| | | |
| | | Double longitude = well.getLongitude(); |
| | |
| | | ardAlarmRadarMove.setLatitude(latitude); |
| | | ardAlarmRadarMove.setUpdateTime(radarAlarmData.getAlarmTime()); |
| | | ardAlarmRadarMove.setRadarId(radarId); |
| | | ardAlarmRadarMove.setWellId(well.getWellId()); |
| | | ardAlarmRadarMoveHandler(ardAlarmRadarMove); |
| | | break; |
| | | case "热源检测": |
| | |
| | | ardAlarmRadarFire.setLatitude(latitude); |
| | | ardAlarmRadarFire.setRadarId(radarId); |
| | | ardAlarmRadarFire.setUpdateTime(radarAlarmData.getAlarmTime()); |
| | | ardAlarmRadarFire.setWellId(well.getWellId()); |
| | | ardAlarmRadarFireHandler(ardAlarmRadarFire); |
| | | break; |
| | | case "雷达抽油机停机": |
| | |
| | | ardAlarmRadarPump.setUpdateTime(radarAlarmData.getAlarmTime()); |
| | | ardAlarmRadarPump.setLongitude(well.getLongitude()); |
| | | ardAlarmRadarPump.setLatitude(well.getLatitude()); |
| | | ardAlarmRadarPump.setWellId(well.getWellId()); |
| | | ardAlarmRadarPumpHandler(ardAlarmRadarPump); |
| | | break; |
| | | } |
| | |
| | | return; |
| | | } |
| | | guideTask.setPriority(Integer.valueOf(priority)); |
| | | guideTask.setTargetPosition(guideDataDto.getTargetPosition());//引导井ID |
| | | guideTask.setTargetPosition(guideDataDto.getTargetPosition());//引导井坐标 |
| | | guideTask.setWellId(guideDataDto.getWellId());//引导井ID |
| | | //消息入队 |
| | | queueHandler.addTaskToQueue(cameraId, guideTask); |
| | | //打印队列 |
| | |
| | | .setAlarmId(ardAlarmRadarMove.getId()) |
| | | .setAlarmType(ardAlarmRadarMove.getAlarmType()) |
| | | .setReceiveTime(ardAlarmRadarMove.getCreateTime()) |
| | | .setWellId(ardAlarmRadarMove.getWellId()) |
| | | .setTargetPosition(coordinate); |
| | | getCameraGuideToQueue(guideDataDto);//获取相机入队 |
| | | } |
| | |
| | | .setAlarmId(ardAlarmRadarFire.getId()) |
| | | .setAlarmType(ardAlarmRadarFire.getAlarmType()) |
| | | .setReceiveTime(ardAlarmRadarFire.getCreateTime()) |
| | | .setWellId(ardAlarmRadarFire.getWellId()) |
| | | .setTargetPosition(coordinate); |
| | | getCameraGuideToQueue(guideDataDto);//获取相机入队 |
| | | } |
| | |
| | | .setAlarmId(ardAlarmRadarPump.getId()) |
| | | .setAlarmType(ardAlarmRadarPump.getAlarmType()) |
| | | .setReceiveTime(ardAlarmRadarPump.getCreateTime()) |
| | | .setWellId(ardAlarmRadarPump.getWellId()) |
| | | .setTargetPosition(coordinate); |
| | | getCameraGuideToQueue(guideDataDto);//获取相机入队 |
| | | } |