| | |
| | | |
| | | 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; |
| | |
| | | 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; |
| | |
| | | private IFileMapper mapper; |
| | | @Autowired |
| | | private IMarkMapper markMapper; |
| | | @Autowired |
| | | private GetPatchesMapper patchesMapper; |
| | | @Autowired |
| | | private IDeviceDictionaryService deviceDictionaryService; |
| | | |
| | |
| | | .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 |