xiewj 1 年間 前
コミット
8e6157d393

+ 0 - 4
720yun_fd_consumer/gis_consumer/src/main/java/com/gis/listener/SceneListener.java

@@ -201,7 +201,6 @@ public class SceneListener {
         }
     }
     private void sendStartMq(SceneQueueDTO param) {
-        if (ObjectUtil.isNotEmpty(param.getSceneSource())&& param.getSceneSource()==6) {
             RelicsSceneInitQueueDTO relicsSceneInitQueueDTO = new RelicsSceneInitQueueDTO();
             relicsSceneInitQueueDTO.setSceneCode(param.getSceneCode());
             relicsSceneInitQueueDTO.setLocation(param.getLocation());
@@ -214,10 +213,8 @@ public class SceneListener {
             relicsSceneInitQueueDTO.setShootCount(param.getShootCount());
             relicsSceneInitQueueDTO.setSceneSource(param.getSceneSource());
             rabbitMqProducerUtil.sendByWorkQueue(relicsInitQueue, relicsSceneInitQueueDTO);
-        }
     }
     private void sendEndMq(SceneQueueDTO param) {
-        if (ObjectUtil.isNotEmpty(param.getSceneSource())&& param.getSceneSource()==6) {
             RelicsSceneInitQueueDTO relicsSceneInitQueueDTO = new RelicsSceneInitQueueDTO();
             relicsSceneInitQueueDTO.setSceneCode(param.getSceneCode());
             relicsSceneInitQueueDTO.setLocation(param.getLocation());
@@ -231,7 +228,6 @@ public class SceneListener {
             relicsSceneInitQueueDTO.setShootCount(param.getShootCount());
             relicsSceneInitQueueDTO.setSceneSource(param.getSceneSource());
             rabbitMqProducerUtil.sendByWorkQueue(relicsInitQueue, relicsSceneInitQueueDTO);
-        }
     }
 
     private static final String CHARACTERS = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";