1

src/main/java/com/fdkankan/manage/httpClient/service/LaserService.java

@@ -279,6 +279,23 @@ public class LaserService {
         rabbitMqProducer.sendByWorkQueue(MqQueueUtil.laserMoveQueue,map);
         //laserClient.migrate(param);
     }
+    public void moveWenBao(String num, String snCode, String toSnCode,Long userId,String newDataSource) {
+        LaserSceneMoveParam param = new LaserSceneMoveParam();
+        param.setSceneCode(num);
+        //param.setSnCode(snCode);
+        param.setToSnCode(toSnCode);
+        param.setUserId(userId);
+        param.setDataSource(newDataSource+"_laserData/laserData");
+        if(userId != null){
+            User user = userService.getById(userId);
+            if(user != null){
+                param.setPhone(user.getUserName());
+            }
+        }
+        Map<String, Object> map = BeanUtil.beanToMap(param);
+        rabbitMqProducer.sendByWorkQueue(MqQueueUtil.laserMoveWenBaoQueue,map);
+        //laserClient.migrate(param);
+    }
 
 
     public void copy(String snCode, String createTime, String newNum, Integer status, String sceneKey, String sceneName, Long userId){

src/main/java/com/fdkankan/manage/mq/common/MqQueueUtil.java

@@ -9,4 +9,5 @@ public class MqQueueUtil {
     public static String sceneRestoreQueue = "scene-rest-store";
     public static String laserUnfreezeScene = "laser-unfreeze-scene";
     public static String laserMoveQueue = "laser-migrate-scene";
+    public static String laserMoveWenBaoQueue = "relics-migrate-scene-queue";
 }

src/main/java/com/fdkankan/manage/service/impl/SceneProServiceImpl.java

@@ -403,6 +403,8 @@ public class SceneProServiceImpl extends ServiceImpl<ISceneProMapper, ScenePro>
             this.lockOrUnLockBySpace(cameraDetail.getCameraId());
         }
         sceneMoveLogService.saveLog(scenePro,scenePlus,camera.getSnCode(),oldCamera.getSnCode(),dataSource,dataSource, null);
+        laserService.moveWenBao(param.getNum(),oldCamera.getSnCode(),camera.getSnCode(),cameraDetail.getUserId(),dataSource);
+
     }