Parcourir la source

【fix】同步配置信息

chengjing il y a 2 ans
Parent
commit
9f76f70c6c

+ 4 - 4
huimv-eartag2-platform/huimv-eartag2-input/src/main/java/com/huimv/eartag2/config/TopicRabbitMQConfig.java

@@ -50,18 +50,18 @@ public class TopicRabbitMQConfig {
 
     // 同步配置消息 原始数据队列
     @Bean
-    public Queue askCmdQueue() {
+    public Queue SysConfigQueue() {
         return new Queue(Const.QUEUE_SYNC_SYS_CONFIG);
     }
     // 同步配置消息 原始数据交换机
     @Bean
-    TopicExchange askCmdExchange() {
+    TopicExchange SysConfigExchange() {
         return new TopicExchange(Const.EXCHANGE_SYNC_SYS_CONFIG);
     }
     //同步配置消息 原始数据绑定关系
     @Bean
-    Binding bindingAskCmdExchangeMessage() {
-        return BindingBuilder.bind(askCmdQueue()).to(askCmdExchange()).with(Const.ROUTING_KEY_SYNC_SYS_CONFIG);
+    Binding bindingSysConfigExchangeMessage() {
+        return BindingBuilder.bind(SysConfigQueue()).to(SysConfigExchange()).with(Const.ROUTING_KEY_SYNC_SYS_CONFIG);
     }
 
 

+ 1 - 0
huimv-eartag2-platform/huimv-eartag2-manage2/src/main/java/com/huimv/eartag2/manage2/service/impl/SysBaseConfigServiceImpl.java

@@ -166,6 +166,7 @@ public class SysBaseConfigServiceImpl extends ServiceImpl<SysBaseConfigMapper, S
         paramsMap.put("farmCode",sysBaseConfigVo.getFarmCode());
         paramsMap.put("ip",sysBaseConfigVo.getIp());
         paramsMap.put("port",sysBaseConfigVo.getPort());
+        paramsMap.put("areaName",sysBaseConfigVo.getAreaName());
         rabbitTemplate.convertAndSend(EXCHANGE_SYNC_SYS_CONFIG,ROUTING_KEY_SYNC_SYS_CONFIG,paramsMap);
         System.out.println("--------------------------------------- 发送设备请求原始数据 >>"+paramsMap);
         return new Result(ResultCode.SUCCESS);