接口

appapi/src/main/java/tech/glinfo/enbao/modules/mq/MqConsumer.java

@@ -122,7 +122,7 @@ public class MqConsumer {
                     shDevice.setProductId(product.getId());
                     otherShDeviceService.save(shDevice);
                     redisUtils.delete("device:save:" + datas.get("mac"));
-                    jmsTemplate.convertAndSend(socketioTopic, JSON.toJSONString(new MapUtils().put(datas.get("mac"), "success")));
+                    jmsTemplate.convertAndSend(socketioTopic, JSON.toJSONString(new MapUtils().put("deviceId", datas.get("mac"))));
                 }
             }
             ShDeviceEntity device = otherShDeviceService.deviceInfo(new MapUtils().put("numbering", datas.get("receiveId")));