| | |
|---|
| | | 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(), "ProvincialIndustrialPark" + "." + mac, JSON.toJSONString(deviceData))); |
|---|
| | | } |
|---|
| | | } |
|---|
