appId同步

yangys

2024-10-10 c34415c583b097c5ad3a19684557d97402d2f230

 collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java

@@ -23,6 +23,7 @@

import com.qianwen.mdc.collect.service.DeviceStateFixPointService;
import com.qianwen.mdc.collect.service.IOTMqttReceiveService;
import com.qianwen.mdc.collect.service.WorkstationAppMappingService;
import com.qianwen.mdc.collect.service.feedback.WorkstationFeedbackService;

import cn.hutool.core.date.DateTime;
@@ -47,6 +48,10 @@
   
   @Autowired
    private WorkstationFeedbackService workstationFeedbackService;
	
   @Autowired
    private WorkstationAppMappingService workstationAppMappingService;
	
   public static final String COLLECT_DATA_TOPIC = "forward/test";
   
   /**
@@ -55,6 +60,8 @@
   public static final String FEEDBACK_TOPIC = "mdc/feedback";
   
   public static final String WOCKSTATION_CREATE_TOPIC = "mdc/workstation-create";
	
   private final String WORKSTATION_APP_MAPPING_CHANGED_TOPIC = "mdc/workstation_app_mapping_changed";
   
   @Bean
    public MqttPahoClientFactory mqttClientFactory() {
@@ -86,7 +93,7 @@
       String clientId = "spring-boot-mqtt-client-inbound"+r.nextInt(1000);
        MqttPahoMessageDrivenChannelAdapter adapter =
                new MqttPahoMessageDrivenChannelAdapter(clientId,
                        mqttClientFactory(), COLLECT_DATA_TOPIC, FEEDBACK_TOPIC,WOCKSTATION_CREATE_TOPIC);//最后一个参数允许多个topic参数
                        mqttClientFactory(), COLLECT_DATA_TOPIC, FEEDBACK_TOPIC,WOCKSTATION_CREATE_TOPIC,WORKSTATION_APP_MAPPING_CHANGED_TOPIC);//最后一个参数允许多个topic参数
        adapter.setCompletionTimeout(5000);
        adapter.setConverter(new DefaultPahoMessageConverter());
        adapter.setQos(1);
@@ -116,7 +123,11 @@
              logger.info("工位创建接收消息={}",workstationId);
              stateFixPointService.deviceStateFixPoint(DateTime.now(), Arrays.asList(workstationId));
              recService.handle((String)message.getPayload());
           }else {//订阅了几个topic就会接收到几个，其他的不会进来
           }else if(WORKSTATION_APP_MAPPING_CHANGED_TOPIC.equals(topic)) {
              String workstationId = (String)message.getPayload();
              logger.info("工位appId映射变化消息={}",workstationId);
              workstationAppMappingService.saveToCache();
           } else {//订阅了几个topic就会接收到几个，其他的不会进来
              logger.warn("topic={},msg={},无对应的处理器",topic,message.getPayload());
           }
        };