|
@@ -1018,11 +1018,12 @@ public class SceneFileBuildServiceImpl extends ServiceImpl<ISceneFileBuildMapper
|
|
|
mqMsg.setBuildType(buildType);
|
|
|
mqMsg.setPath(dataSource);
|
|
|
mqMsg.setCreateTime(DateUtil.format(Calendar.getInstance().getTime(), DateExtUtil.dateStyle));
|
|
|
+ mqMsg.setExt(new HashMap<>());
|
|
|
return mqMsg;
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public ResultData rebuildScene(String num,Boolean force) throws IOException {
|
|
|
+ public ResultData rebuildScene(String num,Boolean force,Boolean deleteExtras) throws IOException {
|
|
|
|
|
|
ScenePro scenePro = sceneProService.getByNum(num);
|
|
|
//如果是v3场景,不允许重算,需要升级v4后再调此接口进行重算
|
|
@@ -1075,7 +1076,7 @@ public class SceneFileBuildServiceImpl extends ServiceImpl<ISceneFileBuildMapper
|
|
|
if(sceneSource == 4){
|
|
|
cameraType = 14L;
|
|
|
}
|
|
|
-
|
|
|
+ BuildSceneCallMessage message = null;
|
|
|
if(sceneSource == 4){
|
|
|
String userName = null;
|
|
|
Long sceneUserId = scenePlus.getUserId();
|
|
@@ -1085,20 +1086,20 @@ public class SceneFileBuildServiceImpl extends ServiceImpl<ISceneFileBuildMapper
|
|
|
}
|
|
|
Camera cameraEntity = cameraService.getById(scenePlus.getCameraId());
|
|
|
fdkkLaserService.saveScene(scenePlus,null,cameraEntity,userName,true);
|
|
|
- BuildSceneCallMessage buildSceneMqMessage = this.getBuildSceneMqMessage(
|
|
|
+ message = this.getBuildSceneMqMessage(
|
|
|
num, cameraType,
|
|
|
fdageData.getString("location") != null && "1".equals(fdageData.getString("location")) ? "sfm" : "slam",
|
|
|
fdageData.getInteger("resolution"), buildType, path);
|
|
|
- rabbitMqProducer.sendByWorkQueue(queueModelingPre, buildSceneMqMessage);
|
|
|
}else{
|
|
|
- BuildSceneCallMessage buildSceneMqMessage = this.getBuildSceneMqMessage(
|
|
|
+ message = this.getBuildSceneMqMessage(
|
|
|
num, cameraType, fdageData.getString("location") != null && "1".equals(fdageData.getString("location")) ? "sfm" : "slam",
|
|
|
fdageData.getInteger("resolution"), buildType,
|
|
|
path);
|
|
|
- rabbitMqProducer.sendByWorkQueue(queueModelingPre, buildSceneMqMessage);
|
|
|
}
|
|
|
-
|
|
|
-
|
|
|
+ if(deleteExtras){
|
|
|
+ message.getExt().put("deleteExtras",deleteExtras);
|
|
|
+ }
|
|
|
+ rabbitMqProducer.sendByWorkQueue(queueModelingPre, message);
|
|
|
scenePlusService.update(new LambdaUpdateWrapper<ScenePlus>()
|
|
|
.set(ScenePlus::getSceneStatus, SceneStatus.wait.code())
|
|
|
.eq(ScenePlus::getNum, num));
|