|
@ -150,8 +150,8 @@ public class AiCompareServiceImpl implements IAiCompareService { |
|
|
List<AiCompareMediaFileDTO> mediaFileDTOList = aiCompareMapper.listMediaFile(jobId); |
|
|
List<AiCompareMediaFileDTO> mediaFileDTOList = aiCompareMapper.listMediaFile(jobId); |
|
|
if(!mediaFileDTOList.isEmpty()){ |
|
|
if(!mediaFileDTOList.isEmpty()){ |
|
|
mediaFileDTOList.stream().forEach(e->{ |
|
|
mediaFileDTOList.stream().forEach(e->{ |
|
|
e.setFilePath(fileService.getObjectUrlOne(MinIOConstants.BUCKET_DKCY,e.getObjectKey(),seconds).toString()); |
|
|
e.setFilePath(fileService.getObjectUrlOne(MinIOConstants.BUCKET_MEDIAFILE,e.getObjectKey(),seconds).toString()); |
|
|
e.setMateFilePath(fileService.getObjectUrlOne(MinIOConstants.BUCKET_DKCY,e.getObjectKey(),seconds).toString()); |
|
|
e.setMateFilePath(fileService.getObjectUrlOne(MinIOConstants.BUCKET_MEDIAFILE,e.getObjectKey(),seconds).toString()); |
|
|
if(isIllegal){ |
|
|
if(isIllegal){ |
|
|
QueryWrapper<AiComparePlateEntity> queryWrapper = new QueryWrapper<AiComparePlateEntity>().eq("file_id", e.getFileId()); |
|
|
QueryWrapper<AiComparePlateEntity> queryWrapper = new QueryWrapper<AiComparePlateEntity>().eq("file_id", e.getFileId()); |
|
|
AiComparePlateEntity plateEntity = aiComparePlateMapper.selectOne(queryWrapper); |
|
|
AiComparePlateEntity plateEntity = aiComparePlateMapper.selectOne(queryWrapper); |
|
@ -199,8 +199,8 @@ public class AiCompareServiceImpl implements IAiCompareService { |
|
|
aiCompareEntity.setId(frameDTO.getCompareId()); |
|
|
aiCompareEntity.setId(frameDTO.getCompareId()); |
|
|
aiCompareMapper.updateById(aiCompareEntity); |
|
|
aiCompareMapper.updateById(aiCompareEntity); |
|
|
frameDTO.setJobName(aiCompareEntity.getJobName()); |
|
|
frameDTO.setJobName(aiCompareEntity.getJobName()); |
|
|
frameDTO.setFileUrl(fileService.getObjectUrlOne(MinIOConstants.BUCKET_DKCY,frameDTO.getFileUrl(),3600).toString()); |
|
|
frameDTO.setFileUrl(fileService.getObjectUrlOne(MinIOConstants.BUCKET_MEDIAFILE,frameDTO.getFileUrl(),3600).toString()); |
|
|
frameDTO.setMateFileUrl(fileService.getObjectUrlOne(MinIOConstants.BUCKET_DKCY,frameDTO.getMateFileUrl(),3600).toString()); |
|
|
frameDTO.setMateFileUrl(fileService.getObjectUrlOne(MinIOConstants.BUCKET_MEDIAFILE,frameDTO.getMateFileUrl(),3600).toString()); |
|
|
String topic = TopicConst.IMAGE +TopicConst.FRAME; |
|
|
String topic = TopicConst.IMAGE +TopicConst.FRAME; |
|
|
mqttGatewayPublish.publish(topic,new CommonTopicRequest().setData(frameDTO),1); |
|
|
mqttGatewayPublish.publish(topic,new CommonTopicRequest().setData(frameDTO),1); |
|
|
return true; |
|
|
return true; |
|
|