package com.dji.sample.patches.utils; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.dji.sample.common.model.CustomClaim; import com.dji.sample.droneairport.dao.DbUploadMapper; import com.dji.sample.droneairport.model.Entity.DbUploadEntity; import com.dji.sample.manage.dao.IDeviceMapper; import com.dji.sample.manage.model.entity.DeviceEntity; import com.dji.sample.media.dao.IFileMapper; import com.dji.sample.media.model.MediaFileEntity; import com.dji.sample.patches.config.pojo.PatchesConfigPojo; import com.dji.sample.patches.dao.GetPatchesMapper; import com.dji.sample.patches.dao.ShpToDataSourceMapper; import com.dji.sample.patches.model.entity.LotInfo; import com.dji.sample.patches.service.GetPatchesService; import com.dji.sample.patches.xml.mode.XMLTemplateModel; import com.dji.sample.patches.xml.utils.CreateWaylineFileUtils; import com.dji.sample.territory.pojo.TerritoryConfigPojo; import com.dji.sample.territory.service.ITbFJService; import com.dji.sample.wayline.model.dto.WaylineFileDTO; import com.dji.sample.wayline.model.dto.WaylineJobDTO; import com.dji.sample.wayline.model.entity.WaylineFileEntity; import com.dji.sample.wayline.model.param.CreateJobParam; import com.dji.sample.wayline.service.IWaylineFileService; import com.dji.sample.wayline.service.IWaylineJobBreakPointService; import com.dji.sample.wayline.service.IWaylineJobService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.core.io.ByteArrayResource; import org.springframework.http.*; import org.springframework.http.client.SimpleClientHttpRequestFactory; import org.springframework.mock.web.MockMultipartFile; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.LinkedMultiValueMap; import org.springframework.util.MultiValueMap; import org.springframework.web.client.RestTemplate; import org.springframework.web.multipart.MultipartFile; import java.nio.file.StandardCopyOption; import java.time.Instant; import java.time.LocalDateTime; import java.io.*; import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; import java.sql.SQLException; import java.time.ZoneId; import java.time.ZonedDateTime; import java.time.format.DateTimeFormatter; import java.util.*; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.stream.Collectors; import static com.dji.sample.patches.utils.MultipartFileTOFileUtil.convert; import static com.dji.sample.patches.utils.ZipUtil.zipFolder; import static com.dji.sample.territory.utils.SM3.sm3; import static com.dji.sample.wayline.model.enums.WaylineTaskTypeEnum.TIMED; import static com.dji.sample.wayline.model.enums.WaylineTemplateTypeEnum.WAYPOINT; @Component public class TimerUtil { @Autowired private ShpToDataSourceMapper shpToDataSourceMapper; @Autowired private PatchesConfigPojo patchesConfigPojo; @Autowired public IWaylineFileService waylineFileService; @Autowired private ITbFJService tbFJService; @Autowired private GetPatchesService getPatchesService; @Autowired private GetPatchesMapper patchesMapper; @Autowired private IWaylineJobService waylineJobService; @Autowired private TerritoryConfigPojo territoryConfigPojo; @Autowired private IWaylineJobBreakPointService jobBreakPointService; @Autowired private IDeviceMapper deviceMapper; @Autowired private DbUploadMapper dbUploadMapper; /** * 定时器，将没有规划的图斑生成航线，并将航线飞完后的成果数据进行保存推送 * * @throws IOException * @throws SQLException */ @Scheduled(cron = "0 0 0 * * ?") public void myTask() throws Exception { Long time = getCurrentTimestampPlus8Hours(14); String taskId = ""; String workspaceId = "4a574db8-4ad3-48f7-9f16-3edbcd8056e1"; // 获取未规划的图斑集合 List> lists = getNoPlan(workspaceId); List> convertedLists = convertToLists(lists); for (List list : convertedLists) { String waylineName = getNowTimeName(); //根据获取的图斑集合获得kmz航线文件 MultipartFile multipartFile = null; try { multipartFile = getFile(waylineName, list, 28.62452712442823, 115.85666327144976); } catch (IOException e) { throw new RuntimeException(e); } taskId = list.get(0).getTaskId(); //上传航线文件 WaylineFileEntity waylineFile = backWayline(multipartFile, waylineName, workspaceId, backclaim().getUsername()); //将为规划的图斑状态更新为已规划 List> listOfLists = new ArrayList<>(); List sublist = new ArrayList<>(); sublist.add(time); // 添加整数值 listOfLists.add(sublist); List lists1 = new ArrayList<>(); lists1.add(time); String times = convertTimestampToFormattedString(time); sendPostWithParameters(waylineName, waylineFile.getWaylineId(), times, lists1, listOfLists); updatePatchesStatu(list); time = addOneHourToTimestamp(time, 1, 0); } } @Scheduled(cron = "0 1 0 * * ?") public void myTask2() { ExecutorService executor = Executors.newSingleThreadExecutor(); executor.execute(() -> { try { dbOperation(); } catch (Exception e) { throw new RuntimeException(e); } }); executor.shutdown(); } // public void myTask3() throws SQLException { // String workspaceId = "4a574db8-4ad3-48f7-9f16-3edbcd8056e1"; // String name = getNowDay(); // List jobs = waylineJobService.selectJobIdByName(name); // List jobIds = jobBreakPointService.selectHaveBreak(jobs); // for (String jobid : jobIds) { // Optional waylineJobDTO = waylineJobService.getJobByJobId(workspaceId, jobid, true); // waylineJobService.publishOneFlightTask(waylineJobDTO.get()); // } // } // @Scheduled(cron = "0 0 1 * * ?") // public void mytask4() throws IOException { // Long time = getCurrentTimestampPlus8Hours(8); // List> listOfLists = new ArrayList<>(); // List sublist = new ArrayList<>(); // sublist.add(time); // 添加整数值 // listOfLists.add(sublist); // List lists1 = new ArrayList<>(); // lists1.add(time); // String times = convertTimestampToFormattedString(time); // sendPostWithParameters("别墅巡查一段", "2a44748a-1500-406f-80cf-ad92186fe8d2", times, lists1, listOfLists); // } // // @Scheduled(cron = "0 50 0 * * ?") // public void mytask5() throws IOException { // Long time = getCurrentTimestampPlus8Hours(9); // List> listOfLists = new ArrayList<>(); // List sublist = new ArrayList<>(); // sublist.add(time); // 添加整数值 // listOfLists.add(sublist); // List lists1 = new ArrayList<>(); // lists1.add(time); // String times = convertTimestampToFormattedString(time); // sendPostWithParameters("别墅巡查二段", "a07229af-471a-4058-9da6-5a2b84308b9e", times, lists1, listOfLists); // } // // @Scheduled(cron = "0 40 1 * * ?") // public void mytask6() throws IOException { // Long time = getCurrentTimestampPlus8Hours(9); // List> listOfLists = new ArrayList<>(); // List sublist = new ArrayList<>(); // sublist.add(time); // 添加整数值 // listOfLists.add(sublist); // List lists1 = new ArrayList<>(); // lists1.add(time); // String times = convertTimestampToFormattedString(time); // sendPostWithParameters("九洲巡河一段", "9f471686-a73a-4e90-8f37-92eed8ed5929", times, lists1, listOfLists); // } // // @Scheduled(cron = "0 40 2 * * ?") // public void mytask7() throws IOException { // Long time = getCurrentTimestampPlus8Hours(9); // List> listOfLists = new ArrayList<>(); // List sublist = new ArrayList<>(); // sublist.add(time); // 添加整数值 // listOfLists.add(sublist); // List lists1 = new ArrayList<>(); // lists1.add(time); // String times = convertTimestampToFormattedString(time); // sendPostWithParameters("九洲巡河二段", "58cd4261-02d7-4c4e-b876-25a4a2630c18", times, lists1, listOfLists); // } // // @Scheduled(cron = "0 30 2 * * ?") // public void mytask8() throws IOException { // Long time = getCurrentTimestampPlus8Hours(12); // List> listOfLists = new ArrayList<>(); // List sublist = new ArrayList<>(); // sublist.add(time); // 添加整数值 // listOfLists.add(sublist); // List lists1 = new ArrayList<>(); // lists1.add(time); // String times = convertTimestampToFormattedString(time); // sendPostWithParameters("定时任务2:30", "c3a7b125-bc0b-49d4-96ed-80743200ab80", times, lists1, listOfLists); // } // @Scheduled(cron = "0 30 2 * * ?") // public void mytask9() throws IOException { // Long time = getCurrentTimestampPlus8Hours(14); // List> listOfLists = new ArrayList<>(); // List sublist = new ArrayList<>(); // sublist.add(time); // 添加整数值 // listOfLists.add(sublist); // List lists1 = new ArrayList<>(); // lists1.add(time); // String times = convertTimestampToFormattedString(time); // sendPostWithParameters("定时任务4:30", "c3a7b125-bc0b-49d4-96ed-80743200ab80", times, lists1, listOfLists); // } // @Scheduled(cron = "0 0 6 * * ?") // public static void mytask10() { // File directory = new File("/tmp"); // String[] partialFileNames = {"temp", "mark"}; // 要匹配的部分文件名 // if (directory.isDirectory()) { // File[] files = directory.listFiles(); // if (files != null) { // for (File file : files) { // for (String partialFileName : partialFileNames) { // if (file.isFile() && file.getName().contains(partialFileName)) { // file.delete(); // break; // 跳出内层循环，以免重复删除同一个文件 // } // } // } // } // } // } /** * 完成对未推送的图斑数据进行整合发送 * * @throws Exception */ @Transactional public void dbOperation() throws Exception { String workspaceId = "4a574db8-4ad3-48f7-9f16-3edbcd8056e1"; String taskId = ""; String dkbh = null; List> lists = convertToLists(getNoPush(workspaceId)); if (lists.isEmpty()){ return; } for (List lotInfo : lists) { for (LotInfo lotInfo1 : lotInfo) { List media = getPatchesService.listPohto(lotInfo1.getDkbh(), workspaceId); //清空FJ表 tbFJService.deleteData(); for (MediaFileEntity mediaFile : media) { //获取媒体文件名里的dkbh和taskId dkbh = getDkbh(mediaFile.getFileName()); //获取该媒体文件的图斑信息 LotInfo lotInfo2 = getPatchesService.getLotinfo(dkbh, workspaceId); taskId = lotInfo2.getTaskId(); tbFJService.insertOneData(mediaFile, lotInfo2); getPatchesService.patchesPushed(taskId, dkbh, workspaceId); } } //存储db到服务器 dbSave(territoryConfigPojo.getResult(), territoryConfigPojo.getResultsave(), taskId); //发送请求给第三方接口 sendPostWithFileAndParameter(territoryConfigPojo.getResult(), taskId); } } @Scheduled(cron = "0 3 17 * * ?") public void GtdbOperation() throws Exception { String taskId = ""; String dkbh = null; String code=""; int count = 0; Set dkbhSet = new HashSet<>(); // 用于存储不同的dkbh List> lists = convertToLists(getNoPush()); if (lists.isEmpty()){ return; } tbFJService.deleteData(); for (List lotInfo : lists) { for (LotInfo lotInfo1 : lotInfo) { List media = getPatchesService.listPohto(lotInfo1.getDkbh()); // 清空FJ表 for (MediaFileEntity mediaFile : media) { // 获取媒体文件名里的dkbh和taskId dkbh = getDkbh(mediaFile.getFileName()); dkbhSet.add(dkbh); // 添加dkbh到set中 // 获取该媒体文件的图斑信息 LotInfo lotInfo2 = getPatchesService.getLotinfo(dkbh); taskId = lotInfo2.getTaskId(); code=lotInfo2.getXzqdm(); count++; // 插入数据到数据库 tbFJService.insertOneData(mediaFile, lotInfo2); getPatchesService.patchesPushed(taskId, dkbh); } } // 存储db到服务器 String dbName = dbSaveGt(territoryConfigPojo.getResult(), territoryConfigPojo.getResultGtsave(), taskId); DbUploadEntity entity = new DbUploadEntity(); File file = new File(territoryConfigPojo.getResult()); byte[] bytesArray = Files.readAllBytes(file.toPath()); long currentTimeMillis = System.currentTimeMillis(); entity.setTimestamp(currentTimeMillis); entity.setSize(getFileSize(file)) ; entity.setHash(sm3(bytesArray)); entity.setCount(dkbhSet.size());// 统计dkbh的数量 entity.setUrl(territoryConfigPojo.getResultGtsave()+"/"+dbName); entity.setRegioncode(code); entity.setExtension(".db"); entity.setAttachmentCount(count); entity.setTaskId(taskId); dbUploadMapper.insert(entity); } } /** * 创建航线 * * @param waylineName * @param list * @return * @throws IOException */ public MultipartFile getFile(String waylineName, List list, double lat, double lon) throws IOException { //南昌28.62452712442823, 115.85666327144976 瑞金 25.8917266，116.020940643 List coordinates = GeoToolsUtil.getRoutePointOrder(list, lat, lon); XMLTemplateModel xmlModel = XMLTemplateModel.init(coordinates, list); CreateWaylineFileUtils.createWaylineFile(xmlModel, patchesConfigPojo.getTemplate(), patchesConfigPojo.getTargetTemplate(), patchesConfigPojo.getWaylines(), patchesConfigPojo.getTargetWaylines()); // 压缩文件夹中的内容 String destKMZFile = patchesConfigPojo.getDestKMZFile() + waylineName + ".kmz"; // 输出的KMZ文件路径 zipFolder(patchesConfigPojo.getSourceDir(), destKMZFile); return convert(new File(destKMZFile)); } /** * 将航线上传Oss * * @param multipartFile * @param waylineName * @param workspaceId * @param username * @return */ public WaylineFileEntity backWayline(MultipartFile multipartFile, String waylineName, String workspaceId, String username) { waylineFileService.importKmzFileBack(multipartFile, workspaceId, username); WaylineFileEntity entity = waylineFileService.selectByName(waylineName); try { waylineFileService.getObjectUrl(workspaceId, entity.getWaylineId()); } catch (SQLException e) { throw new RuntimeException(e); } return entity; } /** * 获取未规划的图斑集合 * * @return */ public List> getNoPlan(String worksapceId) { List list = shpToDataSourceMapper.selectList(new LambdaQueryWrapper() .eq(LotInfo::getIsPlan, 0) .eq(LotInfo::getWorkspaceId, worksapceId)); List> combinedTasks = list.stream() .collect(Collectors.groupingBy(LotInfo::getTaskId)) .values().stream() .map(ArrayList::new) .collect(Collectors.toList()); return combinedTasks; } /** * 更新图斑执行状态 * * @param list */ public void updatePatchesStatu(List list) { for (LotInfo lotInfo : list) { lotInfo.setIsPlan(1); shpToDataSourceMapper.updateById(lotInfo); } } /** * 获取未推送的图斑集合 * * @param workspaceId * @return */ public List> getNoPush(String workspaceId) { List list = patchesMapper.selectList(new LambdaQueryWrapper() .eq(LotInfo::getIsPush, 0) .eq(LotInfo::getType, 2) .eq(LotInfo::getInvestigate, 1) .eq(LotInfo::getWorkspaceId, workspaceId)); return groupTasks(list); } public List> getNoPush() { List list = patchesMapper.selectList(new LambdaQueryWrapper() .eq(LotInfo::getIsPush, 0) .eq(LotInfo::getType, 1) .eq(LotInfo::getInvestigate, 1)); return groupTasks(list); } public static CustomClaim backclaim() { CustomClaim claim = new CustomClaim(); claim.setId("1"); claim.setUsername("adminPC"); claim.setWorkspaceId("4a574db8-4ad3-48f7-9f16-3edbcd8056e1"); claim.setUserType(1); return claim; } public static List> convertToLists(List> listOfLists) { List> convertedLists = new ArrayList<>(); for (List list : listOfLists) { convertedLists.add(new ArrayList<>(list)); } return convertedLists; } /** * 根据taskID对图斑进行分组 * * @param lotInfos * @return */ public static List> groupTasks(List lotInfos) { Map> groupedTasks = new HashMap<>(); for (LotInfo lotInfo : lotInfos) { String taskId = lotInfo.getTaskId(); if (!groupedTasks.containsKey(taskId)) { groupedTasks.put(taskId, new ArrayList<>()); } groupedTasks.get(taskId).add(lotInfo); } return new ArrayList<>(groupedTasks.values()); } public static List> groupTask(List mediaFiles) { Map> groupedTasks = new HashMap<>(); for (MediaFileEntity mediaFile : mediaFiles) { String taskId = getTaskId(mediaFile.getFileName()); if (!groupedTasks.containsKey(taskId)) { groupedTasks.put(taskId, new ArrayList<>()); } groupedTasks.get(taskId).add(mediaFile); } return new ArrayList<>(groupedTasks.values()); } /** * 从filename中获取taskId * * @param filename * @return */ public static String getTaskId(String filename) { int startIndex = filename.indexOf("~") + 1; int endIndex = filename.indexOf("."); return filename.substring(startIndex, endIndex); } /** * 从filename中获取地块编号 * * @param filename * @return */ public static String getDkbh(String filename) { int startIndex = filename.indexOf("点") + 1; int endIndex = filename.indexOf("~"); return filename.substring(startIndex, endIndex); } /** * 将成果发送post请求到第三方接口 * * @param filePath * @param taskId * @throws IOException */ public void sendPostWithFileAndParameter(String filePath, String taskId) throws IOException { // 创建 RestTemplate 实例 try { RestTemplate restTemplate = new RestTemplate(); // 读取文件内容为字节数组 byte[] fileContent = readFileToBytes(filePath); // 构建请求体 MultiValueMap body = buildRequestBody(taskId, fileContent, filePath); // 设置请求头 HttpHeaders headers = new HttpHeaders(); headers.setContentType(MediaType.MULTIPART_FORM_DATA); headers.set("X-SHARE-TOKEN", "981D9B822A9A09DE28B66243AA330DC666E1A82826B58EC3FE63FEB1EC8AA190"); headers.set("X-SHARE-AK", "gwc952d483-bfe5-476b-8431-ae15fe94c006"); // 构建请求实体 HttpEntity> requestEntity = new HttpEntity<>(body, headers); // 发送请求 ResponseEntity response = restTemplate.exchange( "http://39.98.49.177:8083/landCloudWork/artifact/media/upload.action", // "http://localhost:6789/territory/tbdkjbxx/upload", HttpMethod.POST, requestEntity, String.class); } catch (Exception e) { throw new IllegalArgumentException("db推送失败" + e.getMessage()); } } /** * 发送的请求参数 * * @param taskId * @param fileContent * @param filePath * @return */ private static MultiValueMap buildRequestBody(String taskId, byte[] fileContent, String filePath) { MultiValueMap body = new LinkedMultiValueMap<>(); body.add("taskId", taskId); body.add("file", new ByteArrayResource(fileContent) { @Override public String getFilename() { return Paths.get(filePath).getFileName().toString(); } }); return body; } private static byte[] readFileToBytes(String filePath) throws IOException { Path path = Paths.get(filePath); return Files.readAllBytes(path); } public void sendPostWithParameters(String name, String fileId, String time, List taskDays, List> taskPeriods, String jobId,String docksn) throws IOException { try { RestTemplate restTemplate = new RestTemplate(); // 构建请求体 String jsonBody = buildRequestBody(name, fileId, time, taskDays, taskPeriods, jobId,docksn); String workspaceId =getWorkspaceIdByDocksn(docksn); // 设置请求头 HttpHeaders headers = new HttpHeaders(); headers.setContentType(MediaType.APPLICATION_JSON); headers.setAccept(List.of(MediaType.APPLICATION_JSON, MediaType.TEXT_PLAIN, MediaType.ALL)); headers.set("Accept-Language", "zh-CN,zh;q=0.9"); headers.setConnection("keep-alive"); headers.set("x-auth-token", "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ3b3Jrc3BhY2VfaWQiOiJlM2RlYTBmNS0zN2YyLTRkNzktYWU1OC00OTBhZjMyMjgwNjkiLCJzdWIiOiJDbG91ZEFwaVNhbXBsZSIsInVzZXJfdHlwZSI6IjEiLCJuYmYiOjE3MTg1ODUxNTQsImxvZyI6IkxvZ2dlcltjb20uZGppLnNhbXBsZS5jb21tb24ubW9kZWwuQ3VzdG9tQ2xhaW1dIiwiaXNzIjoiREpJIiwiaWQiOiI5Y2MwMGY3Zi0yODMwLTRmM2UtYjdmNC1lN2E1ZjIzYjNjNGYiLCJleHAiOjE4MDQ5ODUxNTQsImlhdCI6MTcxODU4NTE1NCwidXNlcm5hbWUiOiJhZG1pbkRQIn0.eTi9DTYGwcTvnIZasKTFq9OHQgMFS1-m840terb7ss0"); // 构建请求实体 HttpEntity requestEntity = new HttpEntity<>(jsonBody, headers); // 发送请求 ResponseEntity response = restTemplate.exchange( // "https://wrj.shuixiongit.com/drone-api/wayline/api/v1/workspaces/4a574db8-4ad3-48f7-9f16-3edbcd8056e1/flight-tasks", "http://localhost:6789/wayline/api/v1/workspaces/"+workspaceId+"/flight-tasks", HttpMethod.POST, requestEntity, String.class); } catch (Exception e) { throw new IllegalArgumentException("Request failed: " + e.getMessage()); } } public String getWorkspaceIdByDocksn(String docksn){ DeviceEntity entity= deviceMapper.selectOne(new LambdaQueryWrapper().eq(DeviceEntity::getDeviceSn,docksn)); return entity.getWorkspaceId(); } public static void sendPostWithParameters(String name, String fileId, String time, List taskDays, List> taskPeriods) throws IOException { try { RestTemplate restTemplate = new RestTemplate(); // 构建请求体 String jsonBody = buildRequestBody(name, fileId, time, taskDays, taskPeriods); // 设置请求头 HttpHeaders headers = new HttpHeaders(); headers.setContentType(MediaType.APPLICATION_JSON); headers.setAccept(List.of(MediaType.APPLICATION_JSON, MediaType.TEXT_PLAIN, MediaType.ALL)); headers.set("Accept-Language", "zh-CN,zh;q=0.9"); headers.setConnection("keep-alive"); headers.set("x-auth-token", "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ3b3Jrc3BhY2VfaWQiOiJlM2RlYTBmNS0zN2YyLTRkNzktYWU1OC00OTBhZjMyMjgwNjkiLCJzdWIiOiJDbG91ZEFwaVNhbXBsZSIsInVzZXJfdHlwZSI6IjEiLCJuYmYiOjE3MTg1ODUxNTQsImxvZyI6IkxvZ2dlcltjb20uZGppLnNhbXBsZS5jb21tb24ubW9kZWwuQ3VzdG9tQ2xhaW1dIiwiaXNzIjoiREpJIiwiaWQiOiI5Y2MwMGY3Zi0yODMwLTRmM2UtYjdmNC1lN2E1ZjIzYjNjNGYiLCJleHAiOjE4MDQ5ODUxNTQsImlhdCI6MTcxODU4NTE1NCwidXNlcm5hbWUiOiJhZG1pbkRQIn0.eTi9DTYGwcTvnIZasKTFq9OHQgMFS1-m840terb7ss0"); // 构建请求实体 HttpEntity requestEntity = new HttpEntity<>(jsonBody, headers); // 发送请求 ResponseEntity response = restTemplate.exchange( "https://wrj.shuixiongit.com/drone-api/wayline/api/v1/workspaces/4a574db8-4ad3-48f7-9f16-3edbcd8056e1/flight-tasks", // "http://localhost:6789/wayline/api/v1/workspaces/4a574db8-4ad3-48f7-9f16-3edbcd8056e1/flight-tasks", HttpMethod.POST, requestEntity, String.class); } catch (Exception e) { throw new IllegalArgumentException("Request failed: " + e.getMessage()); } } /** * 构建请求体 * * @param name * @param fileId * @param taskDays * @param taskPeriods * @return */ private static String buildRequestBody(String name, String fileId, String select_execute_time, List taskDays, List> taskPeriods) { return String.format("{" + "\"name\":\"%s\"," + "\"file_id\":\"%s\"," + "\"dock_sn\":\"4TADKCM0010016\"," + "\"task_type\":1," + "\"select_execute_time\":\"%s\"," + "\"rth_altitude\":100," + "\"out_of_control_action\":0," + "\"executeTimeContinuousArr\":[{\"index\":1,\"value\":[]}]," + "\"executeTimeRepeatArr\":[{\"index\":1,\"value\":\"\"}]," + "\"rep_fre_val\":1," + "\"rep_fre_type\":3," + "\"rep_rule_type\":1," + "\"time_range\":[]," + "\"rth_mode\":1," + "\"1conValue\":[]," + "\"1repValue\":\"\"," + "\"task_days\":%s," + "\"task_periods\":%s," + "\"wayline_type\":0" + "}", name, fileId, select_execute_time, taskDays, taskPeriods); } private static String buildRequestBody(String name, String fileId, String select_execute_time, List taskDays, List> taskPeriods, String jobid, String dockSn) { // 将 List 和 String 类型的参数格式化为 JSON 字符串 String taskDaysJson = taskDays != null ? taskDays.toString() : "[]"; String taskPeriodsJson = taskPeriods != null ? taskPeriods.toString() : "[]"; // 使用 String.format 来生成 JSON 字符串 return String.format("{" + "\"name\":\"%s\"," + "\"file_id\":\"%s\"," + "\"dock_sn\":\"%s\"," + "\"task_type\":1," + "\"select_execute_time\":\"%s\"," + "\"rth_altitude\":100," + "\"out_of_control_action\":0," + "\"executeTimeContinuousArr\":[{\"index\":1,\"value\":[]}]," + "\"executeTimeRepeatArr\":[{\"index\":1,\"value\":\"\"}]," + "\"rep_fre_val\":1," + "\"rep_fre_type\":3," + "\"rep_rule_type\":1," + "\"time_range\":[]," + "\"rth_mode\":1," + "\"1conValue\":[]," + "\"1repValue\":\"\"," + "\"task_days\":%s," + "\"task_periods\":%s," + "\"wayline_type\":0," + "\"job_id\":\"%s\"" + "}", name, fileId, dockSn, select_execute_time, taskDaysJson, taskPeriodsJson, jobid); } /** * 将上传的db保存一份到本地 * * @param path * @param folder * @param taskId */ public void dbSave(String path, String folder, String taskId) { String sourceFilePath = path; // 源文件路径 String targetFolderPath = fileFold(folder).getPath(); // 目标文件夹路径 try { // 创建目标文件夹 File targetFolder = new File(targetFolderPath); if (!targetFolder.exists()) { targetFolder.mkdirs(); } // 获取当前时间 LocalDateTime currentTime = LocalDateTime.now(); // 格式化时间，生成文件名 String timeName = currentTime.format(DateTimeFormatter.ofPattern("HHmmss")); String fileName = timeName + "_" + taskId + ".db"; // 构建目标文件路径 String targetFilePath = targetFolderPath + File.separator + fileName; // 复制文件到目标文件夹 Path sourcePath = Paths.get(sourceFilePath); Path targetPath = Paths.get(targetFilePath); Files.copy(sourcePath, targetPath, StandardCopyOption.REPLACE_EXISTING); } catch (IOException e) { throw new RuntimeException("Db文件复制失败", e); // 捕获并抛出原始异常 } } public String dbSaveGt(String path, String folder, String taskId) { try { String fileName = taskId + ".db"; // 构建目标文件路径 String targetFilePath = folder + File.separator + fileName; // 复制文件到目标位置 Path sourcePath = Paths.get(path); Path targetPath = Paths.get(targetFilePath); Files.copy(sourcePath, targetPath, StandardCopyOption.REPLACE_EXISTING); return fileName; } catch (IOException e) { throw new RuntimeException("Db文件复制失败", e); // 捕获并抛出原始异常 } } /** * 根据时间创建db存储时的文件夹 * * @param fold * @return */ private static File fileFold(String fold) { // 获取当前时间 LocalDateTime currentTime = LocalDateTime.now(); // 格式化时间，生成文件夹名字 String folderName = currentTime.format(DateTimeFormatter.ofPattern("yyyyMMdd")); // 拼接文件夹路径 String folderPath = fold + File.separator + folderName; // 创建文件夹 File folder = new File(folderPath); if (!folder.exists()) { if (!folder.mkdirs()) { throw new RuntimeException("文件创建失败" + folderPath); } } return folder; } private static File fileFold(String fold,String taskId) { // 获取当前时间 LocalDateTime currentTime = LocalDateTime.now(); // 拼接文件夹路径 String folderPath = fold + File.separator + taskId; // 创建文件夹 File folder = new File(folderPath); if (!folder.exists()) { if (!folder.mkdirs()) { throw new RuntimeException("文件创建失败" + folderPath); } } return folder; } public static Long getCurrentTimestampPlus8Hours(long hours) { // 获取当前时间 LocalDateTime now = LocalDateTime.now(); // 加上8小时 LocalDateTime nowPlus8Hours = now.plusHours(hours); // 转换为UTC时间戳 ZonedDateTime zonedDateTime = nowPlus8Hours.atZone(ZoneId.systemDefault()); long timestamp = zonedDateTime.toInstant().toEpochMilli(); // 将毫秒级时间戳转换为秒级时间戳 return timestamp / 1000; } public static long getNextDayEightAMTimestamp(int hour) { // 获取当前时间 LocalDateTime now = LocalDateTime.now(); // 获取第二天的日期并设置时间为08:00 LocalDateTime nextDayEightAM = now.plusDays(1).withHour(8).withMinute(0).withSecond(0).withNano(0); // 根据传入的hour参数增加小时 LocalDateTime adjustedTime = nextDayEightAM.plusHours(hour); // 转换为时间戳（秒级） ZonedDateTime zonedDateTime = adjustedTime.atZone(ZoneId.systemDefault()); return zonedDateTime.toEpochSecond(); } public static Long addOneHourToTimestamp(Long timestampInSeconds, long hours, long min) { // 将输入的秒级时间戳转换为Instant对象 Instant instant = Instant.ofEpochSecond(timestampInSeconds); // 将Instant对象转换为ZonedDateTime对象，使用系统默认时区 ZonedDateTime zonedDateTime = instant.atZone(ZoneId.systemDefault()); // 加上一小时 ZonedDateTime zonedDateTimePlusOneHour = zonedDateTime.plusHours(hours).plusMinutes(min); // 将ZonedDateTime对象转换回秒级时间戳 return zonedDateTimePlusOneHour.toInstant().getEpochSecond(); } // 方法：将时间戳转换为指定格式的字符串 public static String convertTimestampToFormattedString(Long timestamp) { // 将时间戳转换为Instant对象 Instant instant = Instant.ofEpochMilli(timestamp); // 将Instant对象转换为ZonedDateTime对象，并设置时区为UTC ZonedDateTime chinaTime = instant.atZone(ZoneId.of("Asia/Shanghai")); // 格式化时间 DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm:ss.000'Z'"); return chinaTime.format(formatter); } public static String getNowTimeName() { LocalDateTime currentTime = LocalDateTime.now(); // 格式化时间，生成当前时间 return "云飞行计划" + currentTime.format(DateTimeFormatter.ofPattern("MMddHHmmssSS")); } public static String getTimeName() { LocalDateTime currentTime = LocalDateTime.now(); // 格式化时间，生成当前时间 return "国土调查云" + currentTime.format(DateTimeFormatter.ofPattern("MMddHHmmssSS")); } public static String getNowDay() { LocalDateTime currentTime = LocalDateTime.now(); // 格式化时间，生成当前时间 return currentTime.format(DateTimeFormatter.ofPattern("MMddHHmmssSSS")); } public static long getFileSize(File file) { if (file == null || !file.exists() || !file.isFile()) { return -1L; // 文件不存在或不是普通文件 } return file.length(); } public static void main(String[] args) { File file = new File("DB/result_db.db"); long size = getFileSize(file); System.out.println("文件大小: " + size + " 字节"); } public static void getFileInfo(File file){ long size=getFileSize(file); } }