|
@ -138,7 +138,7 @@ public class AiCompareServiceImpl implements IAiCompareService { |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
String topic = TopicConst.IMAGE +TopicConst.COMPARE; |
|
|
String topic = TopicConst.IMAGE +TopicConst.COMPARE; |
|
|
List<AiCompareMediaFileDTO> mediaFileDTOS = listMediaFile(aiCompareEntity.getJobId(),43200,false); |
|
|
List<AiCompareMediaFileDTO> mediaFileDTOS = listMediaFile(aiCompareEntity.getJobId(),aiCompareEntity.getId(),43200,false); |
|
|
mqttGatewayPublish.publish(topic, new CommonTopicRequest().setData(mediaFileDTOS),1); |
|
|
mqttGatewayPublish.publish(topic, new CommonTopicRequest().setData(mediaFileDTOS),1); |
|
|
insertList.add(aiCompareEntity); |
|
|
insertList.add(aiCompareEntity); |
|
|
} |
|
|
} |
|
@ -146,12 +146,12 @@ public class AiCompareServiceImpl implements IAiCompareService { |
|
|
List<Long> list =compareDTOList.stream().map(e->Convert.toLong(e.get("queueId"))).collect(Collectors.toList()); |
|
|
List<Long> list =compareDTOList.stream().map(e->Convert.toLong(e.get("queueId"))).collect(Collectors.toList()); |
|
|
return aiCompareQueueService.updateStatus(list,AiCompareStatusConstants.QUEUW_TYPE_1); |
|
|
return aiCompareQueueService.updateStatus(list,AiCompareStatusConstants.QUEUW_TYPE_1); |
|
|
} |
|
|
} |
|
|
public List<AiCompareMediaFileDTO> listMediaFile(String jobId,Integer seconds ,boolean isIllegal){ |
|
|
public List<AiCompareMediaFileDTO> listMediaFile(String jobId,Long compareId,Integer seconds ,boolean isIllegal){ |
|
|
List<AiCompareMediaFileDTO> mediaFileDTOList = aiCompareMapper.listMediaFile(jobId); |
|
|
List<AiCompareMediaFileDTO> mediaFileDTOList = aiCompareMapper.listMediaFile(jobId,compareId); |
|
|
if(!mediaFileDTOList.isEmpty()){ |
|
|
if(!mediaFileDTOList.isEmpty()){ |
|
|
mediaFileDTOList.stream().forEach(e->{ |
|
|
mediaFileDTOList.stream().forEach(e->{ |
|
|
e.setFilePath(fileService.getObjectUrlOne(MinIOConstants.BUCKET_MEDIAFILE,e.getObjectKey(),seconds).toString()); |
|
|
e.setFilePath(fileService.getObjectUrlOne(MinIOConstants.BUCKET_MEDIAFILE,e.getObjectKey(),seconds).toString()); |
|
|
e.setMateFilePath(fileService.getObjectUrlOne(MinIOConstants.BUCKET_MEDIAFILE,e.getObjectKey(),seconds).toString()); |
|
|
e.setMateFilePath(fileService.getObjectUrlOne(MinIOConstants.BUCKET_MEDIAFILE,e.getMateObjectKey(),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); |
|
@ -176,7 +176,7 @@ public class AiCompareServiceImpl implements IAiCompareService { |
|
|
int i = aiCompareMapper.updateById(aiCompareEntity); |
|
|
int i = aiCompareMapper.updateById(aiCompareEntity); |
|
|
AiCompareEntity compareEntity = aiCompareMapper.selectById(id); |
|
|
AiCompareEntity compareEntity = aiCompareMapper.selectById(id); |
|
|
String topic = TopicConst.IMAGE +TopicConst.COMPARE; |
|
|
String topic = TopicConst.IMAGE +TopicConst.COMPARE; |
|
|
List<AiCompareMediaFileDTO> mediaFileDTOS = listMediaFile(compareEntity.getJobId(),43200,false); |
|
|
List<AiCompareMediaFileDTO> mediaFileDTOS = listMediaFile(compareEntity.getJobId(),compareEntity.getId(),43200,false); |
|
|
mqttGatewayPublish.publish(topic, new CommonTopicRequest().setData(mediaFileDTOS),1); |
|
|
mqttGatewayPublish.publish(topic, new CommonTopicRequest().setData(mediaFileDTOS),1); |
|
|
return i>0; |
|
|
return i>0; |
|
|
} |
|
|
} |
|
@ -189,7 +189,7 @@ public class AiCompareServiceImpl implements IAiCompareService { |
|
|
@Override |
|
|
@Override |
|
|
public List<AiCompareMediaFileDTO> queryById(Long id) { |
|
|
public List<AiCompareMediaFileDTO> queryById(Long id) { |
|
|
AiCompareEntity aiCompareEntity = aiCompareMapper.selectById(id); |
|
|
AiCompareEntity aiCompareEntity = aiCompareMapper.selectById(id); |
|
|
return listMediaFile(aiCompareEntity.getJobId(),3600,true); |
|
|
return listMediaFile(aiCompareEntity.getJobId(),aiCompareEntity.getId(),3600,true); |
|
|
} |
|
|
} |
|
|
@Override |
|
|
@Override |
|
|
public Boolean pictureFrame(Map<String,Object>objectMap) { |
|
|
public Boolean pictureFrame(Map<String,Object>objectMap) { |
|
|