修改图斑图片审查，行政区转换，航线生成bug

rain

2024-06-05 a46e7ad0f67c78d3b6379bff2605c50a115a2bf1

 src/main/java/com/dji/sample/media/service/impl/FileServiceImpl.java

@@ -2,10 +2,12 @@

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.dji.sample.common.model.Pagination;
import com.dji.sample.common.model.PaginationData;
import com.dji.sample.common.model.ResponseResult;
import com.dji.sample.component.oss.model.OssConfiguration;
import com.dji.sample.component.oss.service.impl.OssServiceContext;
import com.dji.sample.manage.model.dto.DeviceDictionaryDTO;
@@ -15,9 +17,13 @@
import com.dji.sample.media.dao.IMarkMapper;
import com.dji.sample.media.model.*;
import com.dji.sample.media.service.IFileService;
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.TimerUtil;
import com.dji.sample.territory.service.impl.TbFjServiceImpl;
import com.dji.sample.territory.utils.VideoZipUtil;
import com.dji.sample.territory.utils.WaterMarkUtil;
import com.drew.imaging.ImageProcessingException;
import io.minio.MinioClient;
import io.minio.PutObjectArgs;
import org.springframework.beans.factory.annotation.Autowired;
@@ -49,6 +55,8 @@
    private IFileMapper mapper;
    @Autowired
    private IMarkMapper markMapper;
    @Autowired
    private GetPatchesMapper patchesMapper;
    @Autowired
    private IDeviceDictionaryService deviceDictionaryService;

@@ -82,7 +90,7 @@
        return mapper.insert(fileEntity);
    }

    public Integer saveMarkFile(String workspaceId, FileUploadDTO file) throws IOException, FontFormatException {
    public Integer saveMarkFile(String workspaceId, FileUploadDTO file) throws IOException, FontFormatException, ImageProcessingException {
        File file2 = null;
        MediaFileMarkEntity mediaFileMarkEntity = this.fileUploadConvertToMarkEntity(file);
        String url = "http://dev.jxpskj.com:9000/cloud-bucket" + file.getObjectKey();
@@ -92,9 +100,9 @@
        if (!endsWith) {
            file2 = new File(WaterMarkUtil.addWatermark(file1, timestamp, file.getMetadata().getShootPosition().getLat(),
                    file.getMetadata().getShootPosition().getLng(), file.getMetadata().getGimbalYawDegree()).toURI());
        } else {
            file2 = VideoZipUtil.compressVideo(file1, 1600000, 128000, 1280, 720);
        }
        Object data = ImgUtil.getInfo(file1);
        mediaFileMarkEntity.setDronedata(data);
        mediaFileMarkEntity.setWorkspaceId(workspaceId);
        mediaFileMarkEntity.setFileId(UUID.randomUUID().toString());
        mediaFileMarkEntity.setObjectKey("/mark" + file.getPath() + "/" + file.getName());
@@ -107,6 +115,13 @@
        String objectName = mediaFileMarkEntity.getObjectKey(); // 例如 "folder/file.txt"
        uploadFile(endpoint, accessKey, secretKey, bucketName, objectName, file2);
        return markMapper.insert(mediaFileMarkEntity);
    }

    @Override
    public Object mediaInfo(String fileId) {
        MediaFileMarkEntity entity = markMapper.selectOne(new LambdaQueryWrapper<MediaFileMarkEntity>()
                .eq(MediaFileMarkEntity::getFileId, fileId));
        return entity.getDronedata();
    }

    @Override
@@ -124,18 +139,34 @@
                .eq(MediaFileEntity::getWorkspaceId, workspaceId).eq(MediaFileEntity::getJobId, jobId));
    }

    public List<MediaFileEntity> listByIsadd() {
    public List<MediaFileEntity> listByIsadd(String dkbh, String workspaceId) {
        return mapper.selectList(new LambdaQueryWrapper<MediaFileEntity>().eq(MediaFileEntity::getIsadd, 0)
                .like(MediaFileEntity::getFileName, "~"));
                .eq(MediaFileEntity::getWorkspaceId, workspaceId)
                .like(MediaFileEntity::getFileName, dkbh + "~"));
    }

    public int updateExamByFileId(String fileId) {
        // 创建并配置 LambdaUpdateWrapper
        LambdaUpdateWrapper<MediaFileEntity> updateWrapper = new LambdaUpdateWrapper<>();
        updateWrapper.eq(MediaFileEntity::getFileId, fileId)
                .set(MediaFileEntity::getExamine, 0);
        // 执行更新操作并返回更新的行数
        return mapper.update(null, updateWrapper);
    public ResponseResult updateExamByFileId(String fileId) {
        int examineStatus = getExamByFileId(fileId);
        if (examineStatus == 1) {
            LambdaUpdateWrapper<MediaFileEntity> updateWrapper = new LambdaUpdateWrapper<>();
            updateWrapper.eq(MediaFileEntity::getFileId, fileId)
                    .set(MediaFileEntity::getExamine, 0);
            mapper.update(null, updateWrapper);
            return ResponseResult.success("审核未通过");
        } else if (examineStatus == 0) {
            LambdaUpdateWrapper<MediaFileEntity> updateWrapper = new LambdaUpdateWrapper<>();
            updateWrapper.eq(MediaFileEntity::getFileId, fileId)
                    .set(MediaFileEntity::getExamine, 1);
            mapper.update(null, updateWrapper);
            return ResponseResult.success("审核通过");
        }
        return ResponseResult.error("媒体文件不存在");
    }

    public int getExamByFileId(String fileId) {
        MediaFileEntity entity = mapper.selectOne(new LambdaQueryWrapper<MediaFileEntity>()
                .eq(MediaFileEntity::getFileId, fileId));
        return entity.getExamine();
    }

    @Override