| | |
| | | |
| | | boolean exeResult = ModbusUtil2.writeCoilStatus(modbusTcp.getIp(), modbusTcp.getPort(), modbusTcp.getAddrExe(), true); |
| | | if (exeResult) { |
| | | |
| | | ModbusUtil2.writeCoilStatus(modbusTcp.getIp(), modbusTcp.getPort(), modbusTcp.getAddrExe(), false); |
| | | addRun(request); |
| | | //调用异步获取结果 |
| | | progressGasResult(request, modbusTcp); |
| | |
| | | return; |
| | | } |
| | | |
| | | //根据通道数量线程等待,每个通道等待50秒 |
| | | //根据通道数量线程等待,每个通道等待60秒 |
| | | Thread.sleep(list.size() * 50 * 1000); |
| | | log.debug("--------------等待时间完成,开始获取检测结果-------------{}", modbusTcp.getBizCode()); |
| | | |
| | |
| | | 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); |
| | | } |
| | | |
| | | } |