blame | history | patch | commit | commitdiff | ignore whitespace
rain
2024-06-14 8d9a2d656e4ae007590c622e5f7c228adacdca49 
 src/main/java/com/dji/sample/patches/utils/TimerUtil.java


@@ -19,15 +19,21 @@


import com.dji.sample.wayline.service.IWaylineFileService;


import com.dji.sample.wayline.service.IWaylineJobService;




import com.fasterxml.jackson.core.JsonProcessingException;


import com.fasterxml.jackson.databind.JsonNode;


import com.fasterxml.jackson.databind.ObjectMapper;


import com.fasterxml.jackson.databind.node.ObjectNode;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.core.io.ByteArrayResource;


import org.springframework.http.*;


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 org.springframework.web.util.UriComponentsBuilder;




import javax.xml.transform.Result;


import java.nio.file.StandardCopyOption;


@@ -46,6 +52,9 @@


import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.util.concurrent.ExecutorService;


import java.util.concurrent.Executors;


import java.util.concurrent.Future;


import java.util.stream.Collectors;




import static com.dji.sample.patches.utils.MultipartFileTOFileUtil.convert;


@@ -81,7 +90,7 @@


     */


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


    public void myTask() throws Exception {


        String taskId="";


        String taskId = "";


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


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


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


@@ -90,12 +99,38 @@


            long timestamp = System.currentTimeMillis();


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


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


            MultipartFile multipartFile = getFile(waylineName, list);


            MultipartFile multipartFile = null;


            try {


                multipartFile = getFile(waylineName, list);


            } catch (IOException e) {


                throw new RuntimeException(e);


            }


            //上传航线文件


            backWayline(multipartFile, waylineName, workspaceId, backclaim().getUsername());


            //将为规划的图斑状态更新为已规划


            updatePatchesStatu(list);


//            waylineJobService.publishFlightTask(JobParam("656c62f4-cb86-4911-930d-b38089829348"),backclaim());


        }




    }




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


    public void myTask2() {


        ExecutorService executor = Executors.newSingleThreadExecutor();


        executor.execute(() -> {


            try {


                dbOperation();


            } catch (Exception e) {


                throw new RuntimeException(e);


            }


        });


        executor.shutdown();


    }




    @Transactional


    public void dbOperation() throws Exception {


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


        String taskId = "";


        List<List<MediaFileEntity>> list = getNoadd();


        List<List<MediaFileEntity>> medias = convertToLists(list);


        for (List<MediaFileEntity> media : medias) {


@@ -110,23 +145,26 @@


                tbFJService.insertOneData(mediaFile, lotInfo);


                //更新媒体文件的是否添加状态


                updateMediaStatu(mediaFile);




            }


            //存储db到服务器


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




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


            sendPostWithFileAndParameter(territoryConfigPojo.getResult(), taskId);




        }


    }




    /**


     * 创建航线


     *


     * @param waylineName


     * @param list


     * @return


     * @throws IOException


     */


    public MultipartFile getFile(String waylineName, List<LotInfo> list) throws IOException {


        List<PointPO> coordinates = GeoToolsUtil.getRoutePointOrder(list, 28.62703, 115.867719);


        List<PointPO> coordinates = GeoToolsUtil.getRoutePointOrder(list, 28.62452712442823, 115.85666327144976);


        XMLTemplateModel xmlModel = XMLTemplateModel.init(coordinates, list);


        CreateWaylineFileUtils.createWaylineFile(xmlModel, patchesConfigPojo.getTemplate(), patchesConfigPojo.getTargetTemplate(), patchesConfigPojo.getWaylines(), patchesConfigPojo.getTargetWaylines());


        // 压缩文件夹中的内容


@@ -137,6 +175,7 @@




    /**


     * 将航线上传Oss


     *


     * @param multipartFile


     * @param waylineName


     * @param workspaceId


@@ -144,7 +183,7 @@


     * @return


     */


    public String backWayline(MultipartFile multipartFile, String waylineName, String workspaceId, String username) {


        waylineFileService.importKmzFile(multipartFile, workspaceId, username);


        waylineFileService.importKmzFileBack(multipartFile, workspaceId, username);


        WaylineFileEntity entity = waylineFileService.selectByName(waylineName);


        try {


            waylineFileService.getObjectUrl(workspaceId, entity.getWaylineId());


@@ -182,13 +221,15 @@


    }




    public void updateMediaStatu(MediaFileEntity mediaFile) {


            mediaFile.setIsadd(1);


            fileMapper.updateById(mediaFile);


        mediaFile.setIsadd(1);


        fileMapper.updateById(mediaFile);


    }




    public List<List<MediaFileEntity>> getNoadd() {


        List<MediaFileEntity> list = fileMapper.selectList(new LambdaQueryWrapper<MediaFileEntity>()


                .eq(MediaFileEntity::getIsadd, 0).like(MediaFileEntity::getFileName, "~"));


                .eq(MediaFileEntity::getIsadd, 0)


                .eq(MediaFileEntity::getExamine, 1)


                .like(MediaFileEntity::getFileName, "~"));


        List<List<MediaFileEntity>> groupedFilenames = groupTasks(list);


        return groupedFilenames;


    }


@@ -200,6 +241,31 @@


        claim.setWorkspaceId("4a574db8-4ad3-48f7-9f16-3edbcd8056e1");


        claim.setUserType(1);


        return claim;


    }




    public static CreateJobParam JobParam(String waylineId) {


        long timestamp = System.currentTimeMillis();


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


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


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


        listOfLists.add(sublist);


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


        list.add(1715941980L);


        CreateJobParam param = new CreateJobParam();


        param.setName("云飞行调查" + timestamp);


        param.setExecuteStartTimeArr(listOfLists);


        param.setTaskType(TIMED);


        param.setOutOfControlAction(0);


        param.setRepFreType(3);


        param.setRepFreVal(1);


        param.setRepRuleType(1);


        param.setRthAltitude(80);


        param.setWaylineType(WAYPOINT);


        param.setTaskPeriods(listOfLists);


        param.setTaskDays(list);


        param.setFileId(waylineId);


        param.setDockSn("4TADKCMB0010016");


        return param;


    }




    public static <T> List<List<T>> convertToLists(List<List<T>> listOfLists) {


@@ -241,39 +307,55 @@




    /**


     * 将成果发送post请求到第三方接口


     *


     * @param filePath


     * @param taskId


     * @throws IOException


     */


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


        // 创建 RestTemplate 实例


        try{


        RestTemplate restTemplate = new RestTemplate();


        try {


            RestTemplate restTemplate = new RestTemplate();




        // 读取文件内容为字节数组


        byte[] fileContent = readFileToBytes(filePath);


            // 读取文件内容为字节数组


            byte[] fileContent = readFileToBytes(filePath);




        // 构建请求体


        MultiValueMap<String, Object> body = buildRequestBody(taskId, fileContent, filePath);


            // 构建请求体


            MultiValueMap<String, Object> 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");


            // 设置请求头


            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<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(body, headers);


            // 构建请求实体


            HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(body, headers);




        // 发送请求


                ResponseEntity<String> result=restTemplate.exchange(


                "http://39.98.48.180:8087/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());


            // 发送请求


            ResponseEntity<String> response =restTemplate.exchange(


                    "https://jxlandcloud.org.cn/landCloudWork/artifact/media/upload.action",


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


                    HttpMethod.POST,


                    requestEntity,


                    String.class);


            System.out.println(response);


            System.out.println(response);


            System.out.println(response);


            System.out.println(response);


            System.out.println(response);


            System.out.println(response);


            System.out.println(response);


            System.out.println(response);


            System.out.println(response);


            System.out.println(response);


            System.out.println(response);


            System.out.println(response);


            System.out.println(response);


            System.out.println(response);


            System.out.println(response);


        } catch (Exception e) {


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


        }


    }




@@ -296,6 +378,7 @@




    /**


     * 将上传的db保存一份到本地


     *


     * @param path


     * @param folder


     * @param taskId