无人机java后台代码
blame | history | patch | commit | commitdiff | ignore whitespace
rain
2024-07-02 82a90f791678dddbc6e1b98ee9e8028b61a38dfe 
 src/main/java/com/dji/sample/media/service/impl/FileServiceImpl.java


@@ -1,6 +1,9 @@


package com.dji.sample.media.service.impl;




import com.alibaba.fastjson.JSON;


import com.alibaba.fastjson.JSONObject;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;


import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;


import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper;


@@ -20,12 +23,20 @@


import com.dji.sample.media.util.ImgUtil;


import com.dji.sample.patches.dao.GetPatchesMapper;


import com.dji.sample.patches.model.entity.LotInfo;


import com.dji.sample.patches.utils.DistrictCodeUtils;


import com.dji.sample.patches.utils.TimerUtil;


import com.dji.sample.territory.pojo.TerritoryConfigPojo;


import com.dji.sample.territory.service.impl.TbFjServiceImpl;


import com.dji.sample.territory.utils.WaterMarkUtil;


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


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


import com.drew.imaging.ImageProcessingException;


import com.fasterxml.jackson.databind.JsonNode;


import com.fasterxml.jackson.databind.ObjectMapper;


import io.minio.MinioClient;


import io.minio.PutObjectArgs;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


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


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


@@ -59,9 +70,17 @@


    private GetPatchesMapper patchesMapper;


    @Autowired


    private IDeviceDictionaryService deviceDictionaryService;




    @Autowired


    private OssServiceContext ossService;


    @Autowired


    private TerritoryConfigPojo territoryConfigPojo;


    @Autowired


    private IWaylineJobService waylineJobService;


    @Autowired


    private IWaylineFileService waylineFileService;




    private ObjectMapper objectMapper = new ObjectMapper();






    private Optional<MediaFileEntity> getMediaByFingerprint(String workspaceId, String fingerprint) {


        MediaFileEntity fileEntity = mapper.selectOne(new LambdaQueryWrapper<MediaFileEntity>()


@@ -91,49 +110,55 @@


    }




    public void saveMarkFile(String workspaceId, FileUploadDTO file) throws IOException, FontFormatException, ImageProcessingException {


        String name = TimerUtil.getDkbh(file.getName());


        List<LotInfo> lotInfos = patchesMapper.selectList(new LambdaQueryWrapper<LotInfo>().eq(LotInfo::getDkbh, name));


        if (!lotInfos.isEmpty()) {


            LambdaUpdateWrapper<LotInfo> updateWrapper = new LambdaUpdateWrapper<>();


            updateWrapper.eq(LotInfo::getDkbh, name)


                    .eq(LotInfo::getInvestigate, 0)


                    .set(LotInfo::getInvestigate, 1);


            patchesMapper.update(null, updateWrapper);


        }




        boolean endsWith = file.getObjectKey().endsWith(".mp4");


        if (endsWith) {


            MediaFileMarkEntity mediaFileMarkEntity = this.fileUploadConvertToMarkEntity(file);


            mediaFileMarkEntity.setWorkspaceId(workspaceId);


            mediaFileMarkEntity.setFileId(UUID.randomUUID().toString());


            markMapper.insert(mediaFileMarkEntity);


        } else {


            boolean contains = file.getName().contains("~");


            if (contains) {


                String name = TimerUtil.getDkbh(file.getName());


                List<LotInfo> lotInfos = patchesMapper.selectList(new LambdaQueryWrapper<LotInfo>().eq(LotInfo::getDkbh, name));


                if (!lotInfos.isEmpty()) {


                    LambdaUpdateWrapper<LotInfo> updateWrapper = new LambdaUpdateWrapper<>();


                    updateWrapper.eq(LotInfo::getDkbh, name)


                            .eq(LotInfo::getInvestigate, 0)


                            .set(LotInfo::getInvestigate, 1);


                    patchesMapper.update(null, updateWrapper);


                }


            }


            MediaFileMarkEntity mediaFileMarkEntity = this.fileUploadConvertToMarkEntity(file);


            String url = "http://dev.jxpskj.com:9000/cloud-bucket" + file.getObjectKey();


            File file1 = TbFjServiceImpl.downloadFile(url);


            long timestamp = convertToTimestamp(file.getMetadata().getCreatedTime());


            File file2 = new File(WaterMarkUtil.addWatermark(file1, timestamp, file.getMetadata().getShootPosition().getLat(),


                    file.getMetadata().getShootPosition().getLng(), file.getMetadata().getGimbalYawDegree()).toURI());


            Object data = ImgUtil.getInfo(file1);


            mediaFileMarkEntity.setDronedata(data);


            mediaFileMarkEntity.setWorkspaceId(workspaceId);


            mediaFileMarkEntity.setIsadd(0);


            mediaFileMarkEntity.setFileId(UUID.randomUUID().toString());


            mediaFileMarkEntity.setObjectKey("/mark" + file.getPath() + "/" + file.getName());


            mediaFileMarkEntity.setFileName("mark" + file.getName());


            mediaFileMarkEntity.setFilePath("mark" + file.getPath());


            String endpoint = "http://dev.jxpskj.com:9000";


            String accessKey = "pskj";


            String secretKey = "pskj@2021";


            String bucketName = "cloud-bucket";


            String objectName = mediaFileMarkEntity.getObjectKey(); // 例如 "folder/file.txt"


            uploadFile(endpoint, accessKey, secretKey, bucketName, objectName, file2);


            markMapper.insert(mediaFileMarkEntity);


        }


        MediaFileMarkEntity mediaFileMarkEntity = this.fileUploadConvertToMarkEntity(file);


        String url = "http://dev.jxpskj.com:9000/cloud-bucket" + file.getObjectKey();


        File file1 = TbFjServiceImpl.downloadFile(url);


        long timestamp = convertToTimestamp(file.getMetadata().getCreatedTime());


        File file2 = new File(WaterMarkUtil.addWatermark(file1, timestamp, file.getMetadata().getShootPosition().getLat(),


                file.getMetadata().getShootPosition().getLng(), file.getMetadata().getGimbalYawDegree()).toURI());


        Object data = ImgUtil.getInfo(file1);


        mediaFileMarkEntity.setDronedata(data);


        mediaFileMarkEntity.setWorkspaceId(workspaceId);


        mediaFileMarkEntity.setFileId(UUID.randomUUID().toString());


        mediaFileMarkEntity.setObjectKey("/mark" + file.getPath() + "/" + file.getName());


        mediaFileMarkEntity.setFileName("mark" + file.getName());


        mediaFileMarkEntity.setFilePath("mark" + file.getPath());


        String endpoint = "http://dev.jxpskj.com:9000";


        String accessKey = "pskj";


        String secretKey = "pskj@2021";


        String bucketName = "cloud-bucket";


        String objectName = mediaFileMarkEntity.getObjectKey(); // 例如 "folder/file.txt"


        uploadFile(endpoint, accessKey, secretKey, bucketName, objectName, file2);


        markMapper.insert(mediaFileMarkEntity);


    }






    @Override


    public Object mediaInfo(String fileId) {


    public Object mediaInfo(String filename) {


        String name = "mark" + filename;


        MediaFileMarkEntity entity = markMapper.selectOne(new LambdaQueryWrapper<MediaFileMarkEntity>()


                .eq(MediaFileMarkEntity::getFileId, fileId));


                .eq(MediaFileMarkEntity::getFileName, name));


        return entity.getDronedata();


    }




@@ -147,13 +172,70 @@


    }




    @Override


    public PaginationData<MediaFileEntity> MediaQuery(Integer page, Integer pageSize, Long updateStart, Long updateEnd, Long photoStart, Long photoEnd, String jobName, String workspaceId, String type) {


        // 创建分页对象


        Page<MediaFileEntity> pageObj = new Page<>(page, pageSize);




        // 创建查询条件对象


        LambdaQueryWrapper<MediaFileEntity> queryWrapper = new LambdaQueryWrapper<>();




        // 添加查询条件


        queryWrapper.eq(MediaFileEntity::getWorkspaceId, workspaceId);




        if (updateStart != null && updateEnd != null) {


            queryWrapper.between(MediaFileEntity::getCreateTime, updateStart, updateEnd);


        }




        if (photoStart != null && photoEnd != null) {


            queryWrapper.apply("JSON_UNQUOTE(JSON_EXTRACT(metadata, '$.createdTime')) BETWEEN {0} AND {1}", photoStart, photoEnd);


        }




        if (jobName != null && !jobName.isEmpty()) {


            List<String> jobIds = waylineJobService.getJobIds(jobName);


            // 检查 jobIds 列表是否为空


            if (jobIds.isEmpty()) {


                // 如果为空，则直接返回空的分页数据


                return new PaginationData<>(Collections.emptyList(), new Pagination(pageObj));


            }




            queryWrapper.in(MediaFileEntity::getJobId, jobIds);


        }


        if (type != null && !type.isEmpty()) {


            if ("图片".equals(type)) {


                queryWrapper.likeLeft(MediaFileEntity::getFileName, ".jpeg");


            } else if ("视频".equals(type)) {


                queryWrapper.likeLeft(MediaFileEntity::getFileName, ".mp4");


            }


        }


        queryWrapper.last("ORDER BY JSON_EXTRACT(metadata, '$.createdTime') DESC");


        // 执行分页查询


        Page<MediaFileEntity> resultPage = mapper.selectPage(pageObj, queryWrapper);




        // 处理查询结果


        List<MediaFileEntity> records = resultPage.getRecords()


                .stream()


                .peek(mediaFile -> {


                    // 获取任务名称并设置到fileId


                    String taskNameResult = waylineJobService.getName(mediaFile.getJobId());


                    mediaFile.setJobName(taskNameResult);


                })


                .collect(Collectors.toList()


                );




// 返回分页数据


        return new PaginationData<>(records, new Pagination(resultPage));




    }






    @Override


    public List<MediaFileEntity> listMediaFileEntity(String workspaceId, String jobId) {


        return mapper.selectList(new LambdaQueryWrapper<MediaFileEntity>()


                .eq(MediaFileEntity::getWorkspaceId, workspaceId).eq(MediaFileEntity::getJobId, jobId));


    }




    public List<MediaFileEntity> listByIsadd(String dkbh, String workspaceId) {


        return mapper.selectList(new LambdaQueryWrapper<MediaFileEntity>().eq(MediaFileEntity::getIsadd, 0)


        return mapper.selectList(new LambdaQueryWrapper<MediaFileEntity>()


                .eq(MediaFileEntity::getWorkspaceId, workspaceId)


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


    }


@@ -182,6 +264,12 @@


        return entity.getExamine();


    }




    public String getDkbhName(String name) {


        int startIndex = name.indexOf("点") + 1;


        int endIndex = name.indexOf(".");


        return name.substring(startIndex, endIndex);


    }




    @Override


    public PaginationData<MediaFileEntity> getMediaFilesPaginationByWorkspaceId(String workspaceId, long page, long pageSize, MediaFileQueryParam mediaFileQueryParam) {


//        Page<MediaFileEntity> pageData = mapper.selectPage(


@@ -195,6 +283,11 @@




        List<MediaFileEntity> records = pageData.getRecords()


                .stream()


                .peek(mediaFile -> {


                    // 获取任务名称并设置到fileId


                    String taskNameResult = waylineJobService.getName(mediaFile.getJobId());


                    mediaFile.setJobName(taskNameResult);


                })


                .collect(Collectors.toList());


        return new PaginationData<MediaFileEntity>(records, new Pagination(pageData));


    }


@@ -251,7 +344,6 @@


        if (file != null) {


            builder.fileName(file.getName())


                    .filePath(file.getPath())


                    .isadd(0)


                    .examine(1)


                    .fingerprint(file.getFingerprint())


                    .objectKey(file.getObjectKey())


@@ -278,8 +370,6 @@




        if (file != null) {


            builder.fileName(file.getName())


                    .filePath(file.getPath())


                    .isadd(0)


                    .fingerprint(file.getFingerprint())


                    .objectKey(file.getObjectKey())


                    .subFileType(file.getSubFileType())


@@ -344,6 +434,7 @@


                            .bucket(bucketName)


                            .object(objectName)


                            .stream(fileInputStream, file.length(), -1)


                            .contentType("image/jpeg")


                            .build()


            );


            fileInputStream.close();


@@ -356,6 +447,203 @@


        // 获取时间戳（毫秒级别）


        return date.getTime();


    }




    public List<MediaFileEntity> getSameJobId(String jobId) {


        return mapper.selectList(new LambdaQueryWrapper<MediaFileEntity>()


                .eq(MediaFileEntity::getJobId, jobId));


    }






//    public void updateMediaFileNames(String jobId) {


//        // 查询符合条件的数据


//        List<MediaFileEntity> mediaFiles = mapper.selectList(new LambdaQueryWrapper<MediaFileEntity>()


//                        .eq(MediaFileEntity::getJobId, jobId)


////                .eq(MediaFileMarkEntity::getIsadd, 0)


//        );


//


//        // 筛选出name字段不包含'~'的数据


//        List<MediaFileEntity> filteredFiles = mediaFiles.stream()


//                .filter(file -> !file.getFileName().contains("~"))


//                .toList();


//        for (MediaFileEntity currentFile : filteredFiles) {


//            String currentName = currentFile.getFileName();


//            Map<String, Object> currentMetadata = JSON.parseObject(JSON.toJSONString(currentFile.getMetadata()), Map.class);


//            Long currentCreatedTime = (Long) currentMetadata.get("createdTime");


//            // 找到metadata中的createdTime小于当前数据的createdTime且最接近的那条数据


//            Optional<MediaFileEntity> closestFileOpt = mediaFiles.stream()


//                    .filter(file -> {


//                        Map<String, Object> metadata = JSON.parseObject(JSON.toJSONString(file.getMetadata()), Map.class);


//                        Long createdTime = (Long) metadata.get("createdTime");


//                        String filename = file.getFileName();


//                        return createdTime < currentCreatedTime && filename.contains("~");


//                    })


//                    .min((file1, file2) -> {


//                        Map<String, Object> metadata1 = JSON.parseObject(JSON.toJSONString(file1.getMetadata()), Map.class);


//                        Map<String, Object> metadata2 = JSON.parseObject(JSON.toJSONString(file2.getMetadata()), Map.class);


//                        Long time1 = (Long) metadata1.get("createdTime");


//                        Long time2 = (Long) metadata2.get("createdTime");


//                        return Long.compare(currentCreatedTime - time1, currentCreatedTime - time2);


//                    });


//            if (closestFileOpt.isEmpty()) {


//                // 找不到小于的文件，尝试找大于且最接近的文件


//                closestFileOpt = mediaFiles.stream()


//                        .filter(file -> {


//                            Map<String, Object> metadata = JSON.parseObject(JSON.toJSONString(file.getMetadata()), Map.class);


//                            Long createdTime = (Long) metadata.get("createdTime");


//                            String filename = file.getFileName();


//                            return createdTime > currentCreatedTime && filename.contains("~");


//                        })


//                        .min((file1, file2) -> {


//                            Map<String, Object> metadata1 = JSON.parseObject(JSON.toJSONString(file1.getMetadata()), Map.class);


//                            Map<String, Object> metadata2 = JSON.parseObject(JSON.toJSONString(file2.getMetadata()), Map.class);


//                            Long time1 = (Long) metadata1.get("createdTime");


//                            Long time2 = (Long) metadata2.get("createdTime");


//                            return Long.compare(time1 - currentCreatedTime, time2 - currentCreatedTime);


//                        });}


//            if (closestFileOpt.isEmpty()) {


//                throw new RuntimeException("当前图片无法绑定图斑");


//            }


//            // 提取并替换name字段


//            closestFileOpt.ifPresent(closestFile -> {


//                String closestName = closestFile.getFileName();


//                int startIndex = closestName.indexOf("V");


//                if (closestName.contains("W")) {


//                    startIndex = closestName.indexOf("W");


//                }


//                if (closestName.contains("Z")) {


//                    startIndex = closestName.indexOf("Z");


//                }


//                int endIndex = closestName.indexOf(".", startIndex);


//                String replacement = closestName.substring(startIndex, endIndex);


//                int currentStartIndex = currentName.indexOf("V");


//                if (currentName.contains("W")) {


//                    currentStartIndex = closestName.indexOf("W");


//                }


//                if (currentName.contains("Z")) {


//                    currentStartIndex = closestName.indexOf("Z");


//                }


//                int currentEndIndex = currentName.indexOf(".", currentStartIndex);


//                String newName = currentName.substring(0, currentStartIndex)


//                        + replacement


//                        + currentName.substring(currentEndIndex);


//                currentFile.setFileName(newName);


//                updateMediaById(currentFile.getId(), currentFile);


//            });


//        }


//    }


//


//    @Override


//    public void updateMarkMediaFileNames(String jobId) {


//        try {


//


//


//            // 查询符合条件的数据


//            List<MediaFileMarkEntity> mediaFiles = markMapper.selectList(new LambdaQueryWrapper<MediaFileMarkEntity>()


//                            .eq(MediaFileMarkEntity::getJobId, jobId)


////                .eq(MediaFileMarkEntity::getIsadd, 0)


//            );


//


//


//            // 筛选出name字段不包含'~'的数据


//            List<MediaFileMarkEntity> filteredFiles = mediaFiles.stream()


//                    .filter(file -> !file.getFileName().contains("~"))


//                    .toList();


//


//            for (MediaFileMarkEntity currentFile : filteredFiles) {


//                String currentName = currentFile.getFileName();


//                Map<String, Object> currentMetadata = JSON.parseObject(JSON.toJSONString(currentFile.getMetadata()), Map.class);


//                Long currentCreatedTime = (Long) currentMetadata.get("createdTime");


//                // 找到metadata中的createdTime小于当前数据的createdTime且最接近的那条数据


//                Optional<MediaFileMarkEntity> closestFileOpt = mediaFiles.stream()


//                        .filter(file -> {


//                            Map<String, Object> metadata = JSON.parseObject(JSON.toJSONString(file.getMetadata()), Map.class);


//                            Long createdTime = (Long) metadata.get("createdTime");


//                            String filename = file.getFileName();


//                            return createdTime < currentCreatedTime && filename.contains("~");


//                        })


//                        .min((file1, file2) -> {


//                            Map<String, Object> metadata1 = JSON.parseObject(JSON.toJSONString(file1.getMetadata()), Map.class);


//                            Map<String, Object> metadata2 = JSON.parseObject(JSON.toJSONString(file2.getMetadata()), Map.class);


//                            Long time1 = (Long) metadata1.get("createdTime");


//                            Long time2 = (Long) metadata2.get("createdTime");


//                            return Long.compare(currentCreatedTime - time1, currentCreatedTime - time2);


//                        });


//                if (closestFileOpt.isEmpty()) {


//                    // 找不到小于的文件，尝试找大于且最接近的文件


//                    closestFileOpt = mediaFiles.stream()


//                            .filter(file -> {


//                                Map<String, Object> metadata = JSON.parseObject(JSON.toJSONString(file.getMetadata()), Map.class);


//                                Long createdTime = (Long) metadata.get("createdTime");


//                                String filename = file.getFileName();


//                                return createdTime > currentCreatedTime && filename.contains("~");


//                            })


//                            .min((file1, file2) -> {


//                                Map<String, Object> metadata1 = JSON.parseObject(JSON.toJSONString(file1.getMetadata()), Map.class);


//                                Map<String, Object> metadata2 = JSON.parseObject(JSON.toJSONString(file2.getMetadata()), Map.class);


//                                Long time1 = (Long) metadata1.get("createdTime");


//                                Long time2 = (Long) metadata2.get("createdTime");


//                                return Long.compare(time1 - currentCreatedTime, time2 - currentCreatedTime);


//                            });


//                }


//                if (closestFileOpt.isEmpty()) {


//                    throw new RuntimeException("没有符合时间的对象");


//                }


//                // 提取并替换name字段


//                closestFileOpt.ifPresent(closestFile -> {


//                    String closestName = closestFile.getFileName();


//                    int startIndex = closestName.indexOf("V");


//                    if (closestName.contains("W")) {


//                        startIndex = closestName.indexOf("W");


//                    }


//                    if (closestName.contains("Z")) {


//                        startIndex = closestName.indexOf("Z");


//                    }


//                    int endIndex = closestName.indexOf(".", startIndex);


//                    String replacement = closestName.substring(startIndex, endIndex);


//                    int currentStartIndex = currentName.indexOf("V");


//                    if (currentName.contains("W")) {


//                        currentStartIndex = closestName.indexOf("W");


//                    }


//                    if (currentName.contains("Z")) {


//                        currentStartIndex = closestName.indexOf("Z");


//                    }


//                    int currentEndIndex = currentName.indexOf(".", currentStartIndex);


//                    String newName = currentName.substring(0, currentStartIndex)


//                            + replacement


//                            + currentName.substring(currentEndIndex);


//                    currentFile.setFileName(newName);


//                    updateById(currentFile.getId(), currentFile);


//                });


//            }


//        } catch (Exception e) {


//            e.printStackTrace();


//        }


//    }




    public void updateById(Integer id, MediaFileMarkEntity entity) {


        entity.setIsadd(1);


        UpdateWrapper<MediaFileMarkEntity> updateWrapper = new UpdateWrapper<>();


        updateWrapper.eq("id", id);


        markMapper.update(entity, updateWrapper);


    }




    public void updateMediaById(Integer id, MediaFileEntity entity) {


        UpdateWrapper<MediaFileEntity> updateWrapper = new UpdateWrapper<>();


        updateWrapper.eq("id", id);


        mapper.update(entity, updateWrapper);


    }




//    public void getNoaddFile() {


//        List<MediaFileMarkEntity> markEntities = markMapper.selectList(new LambdaQueryWrapper<MediaFileMarkEntity>().eq(MediaFileMarkEntity::getIsadd, 0));


//        for (MediaFileMarkEntity mark : markEntities) {


//            updateMarkMediaFileNames(mark.getJobId());


//            updateMediaFileNames(mark.getJobId());


//        }


//    }




}