src/main/java/com/moral/task/RabbitMQInsertQiandengPark.java | ●●●●● patch | view | raw | blame | history |
src/main/java/com/moral/task/RabbitMQInsertQiandengPark.java
@@ -197,8 +197,6 @@ Map organizationIdMapNew = JSON.parseObject(params); List<Integer> parentIdListNew = (List<Integer>) organizationIdMapNew.get("orgId"); List<Integer> intersection = parentIdListNew.stream().filter(item -> parentIds.contains(item)).collect(Collectors.toList()); System.out.println(deviceData); System.out.println(intersection); intersection.stream().forEach(parentId -> rabbitTemplate.convertAndSend(organization_data.getName(), "QiandengPark" + "." + mac, JSON.toJSONString(deviceData))); } }