增加切图状态

720yun_fd_consumer/src/main/java/com/gis/listener/container/RabbitMQConfig.java

@@ -130,6 +130,7 @@ public class RabbitMQConfig {
         SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory);
         String queueName = queueNameService.getQueueName();
         log.info("sceneWorkQueue 启动,监听队列-{},动态伸缩启动-{}", queueName, isDynamic);
+        sceneWorkQueueListener.setQueueName(queueName);
         container.setQueueNames(queueName);
         container.setMessageListener(sceneWorkQueueListener);
         container.setAutoStartup(true); // 根据配置决定是否自动启动

720yun_fd_consumer/src/main/java/com/gis/listener/container/SceneWorkQueueListener.java

@@ -104,6 +104,11 @@ public class SceneWorkQueueListener implements ChannelAwareMessageListener {
     @Autowired
     private WorkNavigationService workNavigationService;
 
+    private String queueName;
+
+    public void setQueueName(String queueName) {
+        this.queueName = queueName;
+    }
 
     @Autowired
     IMqEcsService mqEcsService;
@@ -126,12 +131,10 @@ public class SceneWorkQueueListener implements ChannelAwareMessageListener {
         String messageId = message.getMessageProperties().getMessageId();
         String msg = new String(message.getBody(), StandardCharsets.UTF_8);
 
-
         WorkEntity workEntity=null;
-
         try {
             log.error("服务实例：{} 正在构建！", SysConstants.hostName);
-            log.info("场景sceneQueueWork开始,队列名:{},id:{},deliveryTag:{},消息体:{}", queueNameService.getQueueName(), messageId,deliveryTag,msg);
+            log.info("场景sceneQueueWork开始,队列名:{},id:{},deliveryTag:{},消息体:{}", queueName, messageId,deliveryTag,msg);
             //设置为计算超时时间过期
             redisUtil.set(modelingKey,msg,SysConstants.modelTimeOut * 3600L,TimeUnit.SECONDS);
             if(redisUtil.hasKey(stopKey)){
@@ -233,7 +236,7 @@ public class SceneWorkQueueListener implements ChannelAwareMessageListener {
                 sendEndMq(param);
                 updateOssStatusJson(param.getSceneCode(),1);
             }
-            log.info("场景计算结束,队列名:{},id:{}", queueNameService.getQueueName(), messageId);
+            log.info("场景计算结束,队列名:{},id:{}", queueName, messageId);
 
         }catch (Exception e){
             if (StrUtil.isNotEmpty(sceneCode)){