无人机java后台代码
blame | history | patch | commit | commitdiff | ignore whitespace
rain
2024-07-04 ac3769f6271403999cec1fa024d4c8a05f1a3e33 
 src/main/java/com/dji/sample/patches/utils/TimerUtil.java


@@ -14,14 +14,18 @@


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;


@@ -42,10 +46,7 @@


import java.time.ZoneId;


import java.time.ZonedDateTime;


import java.time.format.DateTimeFormatter;


import java.util.ArrayList;


import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.util.*;


import java.util.concurrent.ExecutorService;


import java.util.concurrent.Executors;


import java.util.stream.Collectors;


@@ -63,8 +64,7 @@


    private PatchesConfigPojo patchesConfigPojo;


    @Autowired


    public IWaylineFileService waylineFileService;


    @Autowired


    private IFileMapper fileMapper;




    @Autowired


    private ITbFJService tbFJService;


    @Autowired


@@ -76,7 +76,8 @@


    private IWaylineJobService waylineJobService;


    @Autowired


    private TerritoryConfigPojo territoryConfigPojo;




    @Autowired


    private IWaylineJobBreakPointService jobBreakPointService;




    /**


     * 定时器，将没有规划的图斑生成航线，并将航线飞完后的成果数据进行保存推送


@@ -86,16 +87,14 @@


     */


    @Scheduled(cron = "0 0 0 * * ?")


    public void myTask() throws Exception {


        Long time = getCurrentTimestampPlus8Hours();


        Long time = getCurrentTimestampPlus8Hours(14);


        String taskId = "";


        String workspaceId = "4a574db8-4ad3-48f7-9f16-3edbcd8056e1";


//        获取未规划的图斑集合


        List<List<LotInfo>> lists = getNoPlan(workspaceId);


        List<List<LotInfo>> convertedLists = convertToLists(lists);


        for (List<LotInfo> list : convertedLists) {


            long timestamp = System.currentTimeMillis();


            time = addOneHourToTimestamp(time);


            String waylineName = "云飞行调查" + timestamp;


            String waylineName = getNowTimeName();


            //根据获取的图斑集合获得kmz航线文件


            MultipartFile multipartFile = null;


            try {


@@ -113,13 +112,14 @@


            List<Long> lists1 = new ArrayList<>();


            lists1.add(time);


            String times = convertTimestampToFormattedString(time);


            sendPostWithParameters("云飞行计划" + timestamp, waylineFile.getWaylineId(), times, lists1, listOfLists);


            sendPostWithParameters(waylineName, waylineFile.getWaylineId(), times, lists1, listOfLists);


            updatePatchesStatu(list);


            time = addOneHourToTimestamp(time, 1, 0);


        }




    }




    @Scheduled(cron = "0 0 0 * * ?")


    @Scheduled(cron = "0 1 0 * * ?")


    public void myTask2() {


        ExecutorService executor = Executors.newSingleThreadExecutor();


        executor.execute(() -> {


@@ -130,6 +130,68 @@


            }


        });


        executor.shutdown();


    }




    //    public void myTask3() throws SQLException {


//        String workspaceId = "4a574db8-4ad3-48f7-9f16-3edbcd8056e1";


//        String name = getNowDay();


//        List<String> jobs = waylineJobService.selectJobIdByName(name);


//        List<String> jobIds = jobBreakPointService.selectHaveBreak(jobs);


//        for (String jobid : jobIds) {


//            Optional<WaylineJobDTO> 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<List<Long>> listOfLists = new ArrayList<>();


        List<Long> sublist = new ArrayList<>();


        sublist.add(time); // 添加整数值


        listOfLists.add(sublist);


        List<Long> lists1 = new ArrayList<>();


        lists1.add(time);


        String times = convertTimestampToFormattedString(time);


        sendPostWithParameters("别墅巡查一段", "a07229af-471a-4058-9da6-5a2b84308b9e", times, lists1, listOfLists);


    }




    @Scheduled(cron = "0 50 0 * * ?")


    public void mytask5() throws IOException {


        Long time = getCurrentTimestampPlus8Hours(9);


        List<List<Long>> listOfLists = new ArrayList<>();


        List<Long> sublist = new ArrayList<>();


        sublist.add(time); // 添加整数值


        listOfLists.add(sublist);


        List<Long> lists1 = new ArrayList<>();


        lists1.add(time);


        String times = convertTimestampToFormattedString(time);


        sendPostWithParameters("别墅巡查二段", "561ecb37-d673-40f8-a859-05dbfc7d9976", times, lists1, listOfLists);


    }




    @Scheduled(cron = "0 40 1 * * ?")


    public void mytask6() throws IOException {


        Long time = getCurrentTimestampPlus8Hours(9);


        List<List<Long>> listOfLists = new ArrayList<>();


        List<Long> sublist = new ArrayList<>();


        sublist.add(time); // 添加整数值


        listOfLists.add(sublist);


        List<Long> 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<List<Long>> listOfLists = new ArrayList<>();


        List<Long> sublist = new ArrayList<>();


        sublist.add(time); // 添加整数值


        listOfLists.add(sublist);


        List<Long> lists1 = new ArrayList<>();


        lists1.add(time);


        String times = convertTimestampToFormattedString(time);


        sendPostWithParameters("九洲巡河二段", "58cd4261-02d7-4c4e-b876-25a4a2630c18", times, lists1, listOfLists);


    }




    /**


@@ -162,7 +224,7 @@


            dbSave(territoryConfigPojo.getResult(), territoryConfigPojo.getResultsave(), taskId);




            //发送请求给第三方接口


            sendPostWithFileAndParameter(territoryConfigPojo.getResult(), taskId, dkbh, workspaceId);


            sendPostWithFileAndParameter(territoryConfigPojo.getResult(), taskId);




        }


    }


@@ -328,7 +390,7 @@


     * @param taskId


     * @throws IOException


     */


    public void sendPostWithFileAndParameter(String filePath, String taskId, String dkbh, String workspaceId) throws IOException {


    public void sendPostWithFileAndParameter(String filePath, String taskId) throws IOException {


        // 创建 RestTemplate 实例


        try {


            RestTemplate restTemplate = new RestTemplate();


@@ -350,12 +412,11 @@




            // 发送请求


            ResponseEntity<String> response = restTemplate.exchange(


                    "http://39.98.48.180:8087/landCloudWork/artifact/media/upload.action",


                    "http://39.98.49.177:8083/landCloudWork/artifact/media/upload.action",


//                    "http://localhost:6789/territory/tbdkjbxx/upload",


                    HttpMethod.POST,


                    requestEntity,


                    String.class);


            System.out.println(response);


        } catch (Exception e) {


            throw new IllegalArgumentException("db推送失败" + e.getMessage());


        }


@@ -510,12 +571,12 @@


        return folder;


    }




    public static Long getCurrentTimestampPlus8Hours() {


    public static Long getCurrentTimestampPlus8Hours(long hours) {


        // 获取当前时间


        LocalDateTime now = LocalDateTime.now();




        // 加上8小时


        LocalDateTime nowPlus8Hours = now.plusHours(8);


        LocalDateTime nowPlus8Hours = now.plusHours(hours);




        // 转换为UTC时间戳


        ZonedDateTime zonedDateTime = nowPlus8Hours.atZone(ZoneId.systemDefault());


@@ -525,7 +586,7 @@


        return timestamp / 1000;


    }




    public static Long addOneHourToTimestamp(Long timestampInSeconds) {


    public static Long addOneHourToTimestamp(Long timestampInSeconds, long hours, long min) {


        // 将输入的秒级时间戳转换为Instant对象


        Instant instant = Instant.ofEpochSecond(timestampInSeconds);




@@ -533,7 +594,7 @@


        ZonedDateTime zonedDateTime = instant.atZone(ZoneId.systemDefault());




        // 加上一小时


        ZonedDateTime zonedDateTimePlusOneHour = zonedDateTime.plusHours(1);


        ZonedDateTime zonedDateTimePlusOneHour = zonedDateTime.plusHours(hours).plusMinutes(min);




        // 将ZonedDateTime对象转换回秒级时间戳


        return zonedDateTimePlusOneHour.toInstant().getEpochSecond();


@@ -552,4 +613,17 @@


        return chinaTime.format(formatter);


    }




    public static String getNowTimeName() {


        LocalDateTime currentTime = LocalDateTime.now();




        // 格式化时间，生成当前时间


        return "云飞行计划" + currentTime.format(DateTimeFormatter.ofPattern("MMddHHmmssSS"));


    }




    public static String getNowDay() {


        LocalDateTime currentTime = LocalDateTime.now();




        // 格式化时间，生成当前时间


        return "云飞行计划" + currentTime.format(DateTimeFormatter.ofPattern("MMdd"));


    }


}