| | |
| | | //查出数据库纯车辆或纯人脸设备 |
| | | // List<String> serialNumbers = monitorMapper.selectCarOrFace().stream().map(TMonitor::getSerialNumber).collect(Collectors.toList()); |
| | | dataList.forEach(item->{ |
| | | if ("DX_长征大道贡兴路路口东南方向_枪机_细节".equals(item.getName())){ |
| | | log.info("2.数据流入:{}",item); |
| | | log.info("打印状态pingOnline:{}",item.getPingOnline()); |
| | | } |
| | | // if ("DX_长征大道贡兴路路口东南方向_枪机_细节".equals(item.getName())){ |
| | | // log.info("2.数据流入:{}",item); |
| | | // log.info("打印状态pingOnline:{}",item.getPingOnline()); |
| | | // } |
| | | if(item.getPingOnline()) { |
| | | onLineList.add(item.getIp()); |
| | | } else if(!item.getPingOnline()) { |
| | |
| | | .values() |
| | | .stream() |
| | | .map(TMonitorResult::getWorkOrder) |
| | | .collect(Collectors.toMap( |
| | | WorkOrder::getSerialNumber, // 按serialNumber去重 |
| | | Function.identity(), |
| | | (existing, replacement) -> replacement // 重复时保留最后一个,可根据业务调整 |
| | | )) |
| | | .values() |
| | | .stream() |
| | | .collect(Collectors.toList()); |
| | | if (!CollectionUtils.isEmpty(workOrderList)) { |
| | | log.error("pointOnline获得插入工单:{}",workOrderList); |