move使用队列

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

@@ -1,4 +1,5 @@
 package com.fdkankan.manage_jp.httpClient.service;
+import cn.hutool.core.bean.BeanUtil;
 import com.fdkankan.common.util.FileUtils;
 import com.fdkankan.fyun.face.FYunFileServiceInterface;
 import com.fdkankan.manage_jp.httpClient.param.LaserSceneMoveParam;
@@ -318,10 +319,10 @@ public class LaserService {
         return null;
     }
 
-    public FdkkResponse move(String num, String snCode, String toSnCode, Long userId, String newDataSource) {
+    public void move(String num, String snCode, String toSnCode, Long userId, String newDataSource) {
         LaserSceneMoveParam param = new LaserSceneMoveParam();
         param.setSceneCode(num);
-        param.setSnCode(snCode);
+        //param.setSnCode(snCode);
         param.setToSnCode(toSnCode);
         param.setUserId(userId);
         param.setDataSource(newDataSource+"_laserData/laserData");
@@ -331,7 +332,10 @@ public class LaserService {
                 param.setPhone(user.getUserName());
             }
         }
-        return laserClient.migrate(param);
+        Map<String, Object> map = BeanUtil.beanToMap(param);
+        rabbitMqProducer.sendByWorkQueue("laser-migrate-scene",map);
+
+        //return laserClient.migrate(param);
     }
 
 

src/main/java/com/fdkankan/manage_jp/service/impl/TmColdStorageServiceImpl.java

@@ -175,10 +175,8 @@ public class TmColdStorageServiceImpl extends ServiceImpl<ITmColdStorageMapper,
             this.removeByIds(tmColdStorages);
             if(sceneSource == 4 || sceneSource == 5){
                 String dataSource = scenePro == null ? scenePlusExtService.getByPlusId(scenePlus.getId()).getDataSource() : scenePro.getDataSource();
-                FdkkResponse response = laserService.move(num, oldCamera.getSnCode(), camera.getSnCode(), user.getId(), dataSource);
-                if(response.getCode() != 200){
-                    throw new BusinessException(ResultCode.LASER_ERROR);
-                }
+                laserService.move(num, oldCamera.getSnCode(), camera.getSnCode(), user.getId(), dataSource);
+
             }
         }