From c34415c583b097c5ad3a19684557d97402d2f230 Mon Sep 17 00:00:00 2001 From: yangys <y_ys79@sina.com> Date: 星期四, 10 十月 2024 00:30:27 +0800 Subject: [PATCH] appId同步 --- collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java | 15 +++++++++++++-- 1 files changed, 13 insertions(+), 2 deletions(-) diff --git a/collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java b/collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java index ec769d0..df16c29 100644 --- a/collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java +++ b/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);//鏈�鍚庝竴涓弬鏁板厑璁稿涓猼opic鍙傛暟 + mqttClientFactory(), COLLECT_DATA_TOPIC, FEEDBACK_TOPIC,WOCKSTATION_CREATE_TOPIC,WORKSTATION_APP_MAPPING_CHANGED_TOPIC);//鏈�鍚庝竴涓弬鏁板厑璁稿涓猼opic鍙傛暟 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 {//璁㈤槄浜嗗嚑涓猼opic灏变細鎺ユ敹鍒板嚑涓紝鍏朵粬鐨勪笉浼氳繘鏉� + }else if(WORKSTATION_APP_MAPPING_CHANGED_TOPIC.equals(topic)) { + String workstationId = (String)message.getPayload(); + logger.info("宸ヤ綅appId鏄犲皠鍙樺寲娑堟伅={}",workstationId); + workstationAppMappingService.saveToCache(); + } else {//璁㈤槄浜嗗嚑涓猼opic灏变細鎺ユ敹鍒板嚑涓紝鍏朵粬鐨勪笉浼氳繘鏉� logger.warn("topic={},msg={},鏃犲搴旂殑澶勭悊鍣�",topic,message.getPayload()); } }; -- Gitblit v1.9.3