迁移场景 mq

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

@@ -1,4 +1,6 @@
 package com.fdkankan.manage.httpClient.service;
+import com.fdkankan.manage.mq.common.MqQueueUtil;
+import com.fdkankan.rabbitmq.util.RabbitMqProducer;
 import com.google.common.collect.Lists;
 
 import com.alibaba.fastjson.JSONArray;
@@ -50,6 +52,8 @@ public class LaserService {
     ISceneBuildProcessLogService sceneBuildProcessLogService;
     @Autowired
     IScenePlusService scenePlusService;
+    @Autowired
+    RabbitMqProducer rabbitMqProducer;
 
 
     public PageInfo pageList(SceneParam param) {
@@ -203,7 +207,8 @@ public class LaserService {
                 param.setPhone(user.getUserName());
             }
         }
-        laserClient.migrate(param);
+        rabbitMqProducer.sendByWorkQueue(MqQueueUtil.laserMoveQueue,JSONObject.toJSONString(param));
+        //laserClient.migrate(param);
     }
 
 

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

@@ -4,5 +4,7 @@ public class MqQueueUtil {
 
     public static String manageToSaleQueue = "manageToSale";
     public static String updateUserCommand = "updateUser";
-    public static String ucenterScenePayStatus = "scene-pay-status";
+
+    public static String ucenterScenePayStatusQueue = "scene-pay-status";
+    public static String laserMoveQueue = "laser-migrate-scene";
 }

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

@@ -150,14 +150,14 @@ public class SceneProServiceImpl extends ServiceImpl<ISceneProMapper, ScenePro>
     public void lockOrUnLockBySpace(CameraDetail cameraDetail, Long cameraId, Integer payStatus) {
 
         ScenePayStatusVo scenePayStatusVo = new ScenePayStatusVo(cameraDetail.getCameraId());
-        rabbitMqProducer.sendByWorkQueue(MqQueueUtil.ucenterScenePayStatus, JSONObject.toJSONString(scenePayStatusVo));
+        rabbitMqProducer.sendByWorkQueue(MqQueueUtil.ucenterScenePayStatusQueue, JSONObject.toJSONString(scenePayStatusVo));
     }
 
     @Override
     public void lockOrUnLockBySpace(ScenePro scenePro, ScenePlus scenePlus,Integer payStatus) {
         Long sceneId = scenePro == null ? scenePlus.getId() : scenePro.getId();
         ScenePayStatusVo scenePayStatusVo = new ScenePayStatusVo(sceneId,payStatus);
-        rabbitMqProducer.sendByWorkQueue(MqQueueUtil.ucenterScenePayStatus, JSONObject.toJSONString(scenePayStatusVo));
+        rabbitMqProducer.sendByWorkQueue(MqQueueUtil.ucenterScenePayStatusQueue, JSONObject.toJSONString(scenePayStatusVo));
     }