forked from uav/ard-uav-server
ard-route/src/main/java/com/ard/route/service/impl/ArdRouteInfoServiceImpl.java
@@ -1,6 +1,7 @@ package com.ard.route.service.impl; import java.io.IOException; import java.util.ArrayList; import java.util.List; import com.ard.common.exception.ControlException; @@ -13,6 +14,8 @@ import com.ard.data.noflyzone.service.IArdNoFlyZoneService; import com.ard.data.noflyzone.utils.NoFlyZoneUtils; import com.ard.framework.web.service.TokenService; import com.ard.inspection.domain.ArdPointCloud; import com.ard.inspection.mapper.ArdPointCloudMapper; import com.ard.oss.model.MinioUploadResult; import com.ard.oss.service.impl.OssServiceContext; import com.ard.route.domain.djuav.ActionGroupReq; @@ -20,9 +23,11 @@ import com.ard.route.domain.djuav.RoutePointReq; import com.ard.route.domain.djuav.UavRouteReq; import com.ard.route.domain.dto.ArdNoflyDto; import com.ard.route.domain.route.ArdRouteCloud; import com.ard.route.domain.route.ArdRouteInfo; import com.ard.route.domain.route.ArdRouteMission; import com.ard.route.domain.vo.KmzResultVo; import com.ard.route.mapper.ArdRouteCloudMapper; import com.ard.route.mapper.ArdRouteInfoMapper; import com.ard.route.mapper.ArdRouteMissionMapper; import com.ard.route.service.IArdRouteInfoService; @@ -34,14 +39,14 @@ import com.ard.work.service.ITyService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.web.multipart.MultipartFile; import javax.annotation.Resource; import static com.ard.common.utils.SecurityUtils.getUserId; import static com.ard.route.enums.kml.DroneEnumValueEnums.M30_M30T; import static com.ard.route.enums.kml.DroneEnumValueEnums.M350_RTK; import static com.ard.route.util.InitializationUtils.divided_23; import static com.ard.route.util.InitializationUtils.divided23; import static com.ard.route.util.ToolUtils.*; import static com.ard.route.util.UavRouteReqUtils.buildWayLineUploadDTO; import static com.ard.route.util.UavRouteReqUtils.fileConversionEntity; @@ -69,6 +74,12 @@ @Autowired private ArdRouteMissionMapper ardRouteMissionMapper; @Autowired private ArdPointCloudMapper ardPointCloudMapper; @Autowired private ArdRouteCloudMapper ardRouteCloudMapper; @Resource private IArdNoFlyZoneService ardNoFlyZoneService; @@ -86,8 +97,19 @@ ArdRouteInfo ardRouteInfo = ardRouteInfoMapper.selectArdRouteInfoById(id); try { if (ardRouteInfo != null) { if (ardRouteInfo.getRouteData() != null){ ardRouteInfo.setUavRouteReq((UavRouteReq) deserialize(ardRouteInfo.getRouteData())); if ("3".equals(ardRouteInfo.getType())) { if (ardRouteInfo.getRouteData() != null){ UavRouteReq uavRouteReq = new UavRouteReq(); BeanUtils.copyProperties(deserialize(ardRouteInfo.getRouteData()), uavRouteReq); ardRouteInfo.setUavRouteReq(uavRouteReq); } } else { if (ardRouteInfo.getRouteData() != null){ ardRouteInfo.setUavRouteReq((UavRouteReq) deserialize(ardRouteInfo.getRouteData())); } } if (ardRouteInfo.getCloudData() != null){ ardRouteInfo.setArdPointCloudList(deserializeLs(ardRouteInfo.getCloudData())); } } } catch (IOException | ClassNotFoundException e) { @@ -140,7 +162,6 @@ */ @Override public String insertArdRouteInfo(ArdRouteInfo ardRouteInfo) { validateForCreate(ardRouteInfo); checkRouteMissionStatus(ardRouteInfo,"1"); checkRouteMissionStatus(ardRouteInfo,"2"); ardRouteInfo.setId(IdUtils.simpleUUID()); @@ -149,13 +170,45 @@ if (ardRouteInfo.getGroupId() == null){ ardRouteInfo.setGroupId("0"); } ardRouteInfo.getUavRouteReq().setDroneType(subStringDroneType(ardRouteInfo.getAircraft())); KmzResultVo kmzResult = routeService.buildKmz(ardRouteInfo.getUavRouteReq(),ardRouteInfo.getName()); if ("3".equals(ardRouteInfo.getType())){ ardRouteInfo.getUavRouteReq().setHeightMode("EGM96"); }else { ardRouteInfo.getUavRouteReq().setHeightMode("relativeToStartPoint"); } UavRouteReq uavRouteReq = ardRouteInfo.getUavRouteReq(); uavRouteReq.setDroneType(subStringDroneType(ardRouteInfo.getAircraft())); // 机场1：M30/M30T 需保留 aircraft 中的子类型（0-67-0 / 0-67-1）， // 否则 M30T 会按 M30 生成 KMZ（payload 52 而非 53） if (M30_M30T.getValue().equals(uavRouteReq.getDroneType())) { uavRouteReq.setSubDroneType(subStringSubDroneType(ardRouteInfo.getAircraft())); } KmzResultVo kmzResult = routeService.buildKmz(uavRouteReq,ardRouteInfo.getName()); zoomProcessing(ardRouteInfo); ardRouteInfo.setPath(kmzResult.getPath()); ardRouteInfo.setReadOnly("0"); insertRoutePointCloud(ardRouteInfo); ardRouteInfoMapper.insertArdRouteInfo(dataProcessing(ardRouteInfo)); return kmzResult.getPath(); } /** * 新增航信信息时，修改点云数据 * 同时增加航线与点云关联关系表数据 */ private void insertRoutePointCloud(ArdRouteInfo ardRouteInfo) { List<ArdRouteCloud> cloudList = new ArrayList<>(); if (ardRouteInfo.getArdPointCloudList() != null){ for (ArdPointCloud cloudId : ardRouteInfo.getArdPointCloudList()) { ArdRouteCloud cloud = new ArdRouteCloud(); cloud.setRouteId(ardRouteInfo.getId()); cloud.setCloudId(cloudId.getId()); cloudId.setAssociatedState("1"); cloudList.add(cloud); cloudId.setUpdateTime(DateUtils.getNowDate()); ardPointCloudMapper.updateArdPointCloud(cloudId); } ardRouteCloudMapper.batchRouteCloud(cloudList); } } /** @@ -179,17 +232,6 @@ break; default: throw new RuntimeException("不支持的操作类型!!!"); } } } // 验证,只有当前用户是下发人才能创建航线 private void validateForCreate(ArdRouteInfo ardRouteInfo) { ArdRouteMission mission = ardRouteMissionMapper.selectArdRouteMissionById(ardRouteInfo.getMissionId()); if (mission != null){ if (!mission.getIssuerId().equals(getUserId())){ throw new RuntimeException("创建航线，只能创建下发自己的航线任务信息【" + mission.getMissionName() + "】，无法执行操作！"); //return "创建航线，只能创建下发自己的航线任务信息【" + mission.getMissionName() + "】，无法执行操作！"; } } } @@ -236,9 +278,14 @@ // 先删除航线 delOssService(route); // 再生成航线 ardRouteInfo.getUavRouteReq().setDroneType(subStringDroneType(ardRouteInfo.getAircraft())); UavRouteReq uavRouteReq = ardRouteInfo.getUavRouteReq(); uavRouteReq.setDroneType(subStringDroneType(ardRouteInfo.getAircraft())); // 机场1：M30T(0-67-1) 需同步子类型，避免编辑后按 M30 重新生成 KMZ if (M30_M30T.getValue().equals(uavRouteReq.getDroneType())) { uavRouteReq.setSubDroneType(subStringSubDroneType(ardRouteInfo.getAircraft())); } zoomProcessing(ardRouteInfo); kmzResult = routeService.buildKmz(ardRouteInfo.getUavRouteReq(), ardRouteInfo.getName()); kmzResult = routeService.buildKmz(uavRouteReq, ardRouteInfo.getName()); if ("更新航线kmz文件失败".equals(kmzResult.getData())) { return 0; } @@ -255,7 +302,7 @@ for (ActionGroupReq actionGroupReq : routePointReq.getActionGroupList()) { for (PointActionReq action : actionGroupReq.getActions()) { if (action.getZoom() != null){ action.setZoom(divided_23(action.getZoom())); action.setZoom(divided23(action.getZoom())); } } } @@ -267,14 +314,19 @@ private ArdRouteInfo dataProcessing(ArdRouteInfo ardRouteInfo) { // 航线数据 byte[] routeData = null; byte[] cloudData = null; try { if (ardRouteInfo.getUavRouteReq() != null){ routeData = serialize(ardRouteInfo.getUavRouteReq()); } if (ardRouteInfo.getArdPointCloudList() != null){ cloudData = serialize(ardRouteInfo.getArdPointCloudList()); } } catch (IOException e) { throw new RuntimeException(e); } ardRouteInfo.setRouteData(routeData); ardRouteInfo.setCloudData(cloudData); ardRouteInfo.setPointCount(getPointCount(ardRouteInfo)); return ardRouteInfo; } @@ -431,6 +483,9 @@ ArdRouteInfo route = ardRouteInfoMapper.selectArdRouteInfoById(id); try { route.setUavRouteReq((UavRouteReq) deserialize(route.getRouteData())); if (route.getCloudData() != null){ route.setArdPointCloudList(deserializeLs(route.getCloudData())); } } catch (IOException | ClassNotFoundException e) { throw new RuntimeException(e); } @@ -472,6 +527,7 @@ WaylineInfo WaylineInfo = new WaylineInfo(); WaylineInfo.setBoxSn(boxSn); WaylineInfo.setWaylineId(route.getId()); WaylineInfo.setRouteName(route.getName()); UavWaylineCache.put(WaylineInfo); // 4.调用接口 tyService.wayLineUpload(wayLineUploadDTO);
