|
@@ -41,13 +41,13 @@ import java.util.List;
|
|
|
public class SceneMarkShapeServiceImpl extends ServiceImpl<MarkShapeMapper, SceneMarkShape> implements ISceneMarkShapeService {
|
|
|
@Autowired
|
|
|
private RabbitMqProducer rabbitMqProducer;
|
|
|
- @Value("${queue.scene.yolov5-re-detect-queue}")
|
|
|
- private String yolov5ReDetectQueue;
|
|
|
+ @Value("${queue.scene.yolov5-re-train-queue}")
|
|
|
+ private String yolov5TrainQueue;
|
|
|
@Value("${main.url}")
|
|
|
private String mainUrl;
|
|
|
|
|
|
@Override
|
|
|
- public void editReDetectStatus(SceneMarkShapeParamVO param) {
|
|
|
+ public void editTrainStatus(SceneMarkShapeParamVO param) {
|
|
|
SceneMarkShape byNumAndImagePath = findByNumAndImagePath(param.getNum(), param.getImagePath());
|
|
|
if (ObjectUtil.isNotNull(byNumAndImagePath)){
|
|
|
byNumAndImagePath.setReDetect(0);
|
|
@@ -57,14 +57,14 @@ public class SceneMarkShapeServiceImpl extends ServiceImpl<MarkShapeMapper, Scen
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public List<SceneMarkShape> findByReDetectStatus(Integer reDetect){
|
|
|
+ public List<SceneMarkShape> findByReTrainStatus(Integer reDetect){
|
|
|
LambdaQueryWrapper<SceneMarkShape> wrapper = Wrappers.lambdaQuery();
|
|
|
wrapper.eq(SceneMarkShape::getReDetect,reDetect);
|
|
|
return list(wrapper);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public List<SceneMarkShape> findByToDetectStatus(Integer toDetect) {
|
|
|
+ public List<SceneMarkShape> findByToTrainStatus(Integer toDetect) {
|
|
|
QueryWrapper queryWrapper = new QueryWrapper();
|
|
|
queryWrapper.select("DISTINCT num")
|
|
|
.eq("to_detect",toDetect) ;
|
|
@@ -72,9 +72,9 @@ public class SceneMarkShapeServiceImpl extends ServiceImpl<MarkShapeMapper, Scen
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public void reDetectScene(SceneMarkShapeReDetectParamVO param) {
|
|
|
+ public void trainScene(SceneMarkShapeReDetectParamVO param) {
|
|
|
//查询需要重新训练的图片
|
|
|
- List<SceneMarkShape> reDetectStatuList = findByReDetectStatus(1);
|
|
|
+ List<SceneMarkShape> reDetectStatuList = findByReTrainStatus(1);
|
|
|
for (SceneMarkShape shape : reDetectStatuList) {
|
|
|
SceneMarkShapeReDetectParamVO paramVO=new SceneMarkShapeReDetectParamVO();
|
|
|
paramVO.setWebSite(mainUrl);
|
|
@@ -84,10 +84,10 @@ public class SceneMarkShapeServiceImpl extends ServiceImpl<MarkShapeMapper, Scen
|
|
|
paramVO.setNum(shape.getNum());
|
|
|
paramVO.setImagePath(shape.getImagePath());
|
|
|
paramVO.setDetectType(1);
|
|
|
- rabbitMqProducer.sendByWorkQueue(yolov5ReDetectQueue,paramVO);
|
|
|
+ rabbitMqProducer.sendByWorkQueue(yolov5TrainQueue,paramVO);
|
|
|
}
|
|
|
//查询需要进入训练的场景
|
|
|
- List<SceneMarkShape> byToDetectStatus = findByToDetectStatus(0);
|
|
|
+ List<SceneMarkShape> byToDetectStatus = findByToTrainStatus(0);
|
|
|
for (SceneMarkShape shape : byToDetectStatus) {
|
|
|
SceneMarkShapeReDetectParamVO paramVO=new SceneMarkShapeReDetectParamVO();
|
|
|
paramVO.setWebSite(mainUrl);
|
|
@@ -96,7 +96,7 @@ public class SceneMarkShapeServiceImpl extends ServiceImpl<MarkShapeMapper, Scen
|
|
|
}
|
|
|
paramVO.setNum(shape.getNum());
|
|
|
paramVO.setDetectType(2);
|
|
|
- rabbitMqProducer.sendByWorkQueue(yolov5ReDetectQueue,paramVO);
|
|
|
+ rabbitMqProducer.sendByWorkQueue(yolov5TrainQueue,paramVO);
|
|
|
}
|
|
|
}
|
|
|
|