| | |
|---|
| | | monitorList.add(monitor); |
|---|
| | | ywPointList.add(point); |
|---|
| | | } |
|---|
| | | log.error("同步mongo新ywpoint数据{}",ywPointList); |
|---|
| | | |
|---|
| | | //添加老数据 |
|---|
| | | List<String> numbers = CollectionUtils.isEmpty(monitorList) ? new ArrayList<>() : monitorList.stream().map(TMonitor::getSerialNumber).collect(Collectors.toList()); |
|---|
| | | monitorVOMap.forEach((key, value) -> { |
|---|
| | |
|---|
| | | ywPointList.add(value); |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | log.error("同步mongo新加旧ywpoint数据{}",ywPointList); |
|---|
| | | |
|---|
| | | log.info("result集合{},设备集合{},点位集合{}", oneMachineFileResults.size(), monitorList.size(), ywPointList.size()); |
|---|
| | | //插入数据库 |
|---|
| | | if (!CollectionUtils.isEmpty(monitorList)) { |
|---|
