|
@@ -372,6 +372,12 @@ public class CameraServiceImpl extends ServiceImpl<ICameraMapper, Camera> implem
|
|
|
}
|
|
|
cameraDetails.add(cameraDetail);
|
|
|
}
|
|
|
+ List<Long> cameraIds = cameraDetails.stream().map(CameraDetail::getCameraId).collect(Collectors.toList());
|
|
|
+ if(!cameraIds.isEmpty()){
|
|
|
+ HashMap<String,Object> map = new HashMap<>();
|
|
|
+ map.put("cameraIds",cameraIds);
|
|
|
+ rabbitMqProducer.sendByWorkQueue("camera-update-agent",map);
|
|
|
+ }
|
|
|
return cameraDetailService.saveOrUpdateBatch(cameraDetails) ? cameraDetails.size() : 0;
|
|
|
}
|
|
|
|