| | |
| | | return; |
| | | } |
| | | |
| | | //根据通道数量线程等待,每个通道等待50秒 |
| | | Thread.sleep(list.size() * 50 * 1000); |
| | | //根据通道数量线程等待,每个通道等待60秒 |
| | | Thread.sleep(list.size() * 60 * 1000); |
| | | log.debug("--------------等待时间完成,开始获取检测结果-------------{}", modbusTcp.getBizCode()); |
| | | |
| | | boolean isRun = isRun(request); |
| | |
| | | modbusTcpTemp.setAddrExe(ServerUtil.getAddrExe(gasModbus.getPh3())); |
| | | check = ModbusUtil2.readHoldingRegister(modbusTcpTemp.getIp(), modbusTcpTemp.getPort(), modbusTcpTemp.getAddrExe()); |
| | | gasResult.setPh3(check); |
| | | |
| | | log.debug("----通道{},Co2={},O2={},Ph3={}", gasModbus.getPasscode(), gasResult.getCo2(), gasResult.getO2(), gasResult.getPh3()); |
| | | results.add(gasResult); |
| | | } |
| | | |
| | |
| | | //通知解析 |
| | | analysisService.analysisGas(request, results); |
| | | } catch (Exception e) { |
| | | log.error("------------更新气体检测结果进度失败,执行异常-----{}--{}", modbusTcp.getBizCode(), e.getMessage()); |
| | | log.error("------------更新气体检测结果进度失败,执行异常-----{}--{}", modbusTcp.getBizCode(), e); |
| | | } |
| | | |
| | | } |