Browse Source

laser-复制区分队列

lyhzzz 10 months ago
parent
commit
4f49c77704

+ 6 - 0
src/main/java/com/fdkankan/scene/service/impl/LaserServiceImpl.java

@@ -29,6 +29,8 @@ public class LaserServiceImpl implements ILaserService {
     private String cloudPointBuild;
     @Value("${queue.application.laser.copy-scene:laser-copy-scene}")
     private String laserCopyScene;
+    @Value("${queue.application.laser.copy-scene:laser-copy-scene-init}")
+    private String laserInitCopyScene;
     @Override
     public void copy(String oldNum, String newNum, String path, Boolean flag) {
         Map<String,Object> params = new HashMap<>();
@@ -36,6 +38,10 @@ public class LaserServiceImpl implements ILaserService {
         params.put("oldSceneCode", oldNum);
         params.put("path",path);
         params.put("init",flag);
+        if(flag){
+            rabbitMqProducer.sendByWorkQueue(laserInitCopyScene,params);
+            return;
+        }
         rabbitMqProducer.sendByWorkQueue(laserCopyScene,params);
     }