| | |
| | | BaseReqData reqData = new BaseReqData(); |
| | | BaseResp resp; |
| | | |
| | | |
| | | for (int i = 0 ;i<3;i++){ |
| | | for (GatewayDevice device : list) { |
| | | for (int i = 0 ;i<3;i++){ |
| | | |
| | | try{ |
| | | //如果不是粮情分机跳过 |
| | | if (!GatewayDeviceType.TYPE_07.getCode().equals(device.getType())) { |
| | | continue; |
| | | } |
| | | if( i>0 && !device.getDeviceSn().startsWith("91510704731594658J002")){ |
| | | if( i>0 && !(device.getDeviceId().startsWith("91510704731594658J001") ||device.getDeviceId().startsWith("91510704731594658J002") || device.getDeviceId().startsWith("91510700205404914T001"))){ |
| | | continue; |
| | | } |
| | | reqData.setDeviceId(device.getDeviceId()); |
| | |
| | | GatewaySyncGranService syncGrainService = gatewayRemoteManager.getSyncGrainService(device.getSyncProtocol()); |
| | | resp = syncGrainService.syncGrain(reqData); |
| | | log.info("命令发送结果:"+resp.toString()); |
| | | Thread.sleep(60000); |
| | | Thread.sleep(120000); |
| | | }catch (Exception e){ |
| | | log.error(e.getMessage(),e); |
| | | } |
| | |
| | | //如果是异常值,执行调整数据 TODO |
| | | if (Double.valueOf(curTemp) < -99.9) { |
| | | |
| | | curTemp = output.getAvgTemperature(); |
| | | //curTemp = output.getAvgTemperature(); |
| | | |
| | | } else { |
| | | //判断最大 |
| | |
| | | int cableZ = cableData.getCableZ(); |
| | | int cableY = cableData.getCableY(); |
| | | |
| | | int sumNum = temps.size(); |
| | | log.info("temps:" + temps.toString()); |
| | | int sumNum = 0; |
| | | log.info("temps:" + temps.toString()); |
| | | //数据封装 |
| | | GrainData grain = new GrainData(); |
| | | grain.setMessageId(ScConstant.getMessageId()); |
| | |
| | | |
| | | double curTemp; |
| | | int x = 0, y = 0, z = 0; |
| | | for (int i = 0; i < sumNum; i++) { |
| | | for (int i = 0; i < temps.size(); i++) { |
| | | curTemp = temps.get(i); |
| | | position = i; |
| | | |
| | |
| | | |
| | | temperature.add(new GrainTemp(cableNum + "", z + "", curTemp + "", position + "")); |
| | | |
| | | //求最大最小值 |
| | | if (curTemp < -900) { |
| | | sumNum--; |
| | | } else { |
| | | // //求最大最小值 |
| | | // if (curTemp < -900) { |
| | | // // sumNum--; |
| | | // } else { |
| | | // sumT += curTemp; |
| | | // if (curTemp > max) { |
| | | // max = curTemp; |
| | | // } |
| | | // if (curTemp < min) { |
| | | // min = curTemp; |
| | | // } |
| | | // } |
| | | if (curTemp > max && curTemp < 40) { |
| | | max = curTemp; |
| | | } |
| | | if (curTemp < min && curTemp > 3) { |
| | | min = curTemp; |
| | | } |
| | | if(curTemp > 3 && curTemp < 40){ |
| | | sumT += curTemp; |
| | | if (curTemp > max) { |
| | | max = curTemp; |
| | | } |
| | | if (curTemp < min) { |
| | | min = curTemp; |
| | | } |
| | | sumNum++; |
| | | } |
| | | } |
| | | |
| | |
| | | GrainOutPut outPut = new GrainOutPut(); |
| | | |
| | | |
| | | double max = ReMessageBuilder.MAX_TEMP, min = ReMessageBuilder.MIN_TEMP, sumT = 0.0, sumNum = cableX |
| | | * cableY * cableZ; |
| | | double max = ReMessageBuilder.MAX_TEMP, min = ReMessageBuilder.MIN_TEMP, sumT = 0.0, sumNum = 0; |
| | | |
| | | List<GrainTemp> temperature = new ArrayList<>(); |
| | | //根号 |
| | |
| | | temperature.add(new GrainTemp(cableNum + "", z + "", curTemp + "", position + "")); |
| | | |
| | | //求最大最小值 |
| | | if (curTemp < -900) { |
| | | sumNum--; |
| | | } else { |
| | | // if (curTemp < -900) { |
| | | // sumNum--; |
| | | // } else { |
| | | // sumT += curTemp; |
| | | // if (curTemp > max) { |
| | | // max = curTemp; |
| | | // } |
| | | // if (curTemp < min) { |
| | | // min = curTemp; |
| | | // } |
| | | // } |
| | | if (curTemp > max && curTemp < 40) { |
| | | max = curTemp; |
| | | } |
| | | if (curTemp < min && curTemp > 3) { |
| | | min = curTemp; |
| | | } |
| | | if(curTemp > 3 && curTemp < 40){ |
| | | sumT += curTemp; |
| | | if (curTemp > max) { |
| | | max = curTemp; |
| | | } |
| | | if (curTemp < min) { |
| | | min = curTemp; |
| | | } |
| | | sumNum++; |
| | | } |
| | | } |
| | | |
| | |
| | | outPut.setTemperature(temperature); |
| | | outPut.setAvgTemperature(NumberUtil.keepPrecision((sumT / sumNum), 1) + ""); |
| | | outPut.setMinTemperature(min + ""); |
| | | outPut.setMaxTemperature(min + ""); |
| | | outPut.setMaxTemperature(max + ""); |
| | | List<GrainTH> ths = new ArrayList<>(); |
| | | |
| | | ths.add(new GrainTH(thDto.getTempIn() != null ? thDto.getTempIn() + "" : "", thDto.getHumidityIn() != null ? thDto.getHumidityIn() + "" : "", "1")); |
| | |
| | | // 发送命令 |
| | | InvokeResult message = BhznGrainV2ServerEngine.push(device.getIp(), device.getPort(), BytesUtil.hexStrToBytes(hexStr)); |
| | | |
| | | log.error("平台------>>>>控制柜:发送粮情检测命令-{}", message); |
| | | log.info("平台------>>>>控制柜:发送粮情检测命令-{}-{}", message,hexStr); |
| | | |
| | | // 封装返回信息 |
| | | if (!InvokeResult.SUCCESS.getCode().equals(message.getCode())) { |
| | |
| | | int cableY = cableData.getCableY(); |
| | | int cableX = cableData.getCableX(); |
| | | |
| | | int sumNum = temps.size(); |
| | | int sumNum = 0; |
| | | |
| | | //数据封装 |
| | | GrainData grain = new GrainData(); |
| | |
| | | |
| | | double curTemp; |
| | | int x = 0, y = 0, z = 0; |
| | | for (int i = 0; i < sumNum; i++) { |
| | | for (int i = 0; i < temps.size(); i++) { |
| | | curTemp = temps.get(i); |
| | | position = i; |
| | | |
| | |
| | | temperature.add(new GrainTemp(cableNum + "", z + "", curTemp + "", position + "")); |
| | | |
| | | //求最大最小值 |
| | | if (curTemp < -900) { |
| | | sumNum--; |
| | | } else { |
| | | // if (curTemp < -900) { |
| | | // sumNum--; |
| | | // } else { |
| | | // sumT += curTemp; |
| | | // if (curTemp > max) { |
| | | // max = curTemp; |
| | | // } |
| | | // if (curTemp < min) { |
| | | // min = curTemp; |
| | | // } |
| | | // } |
| | | if (curTemp > max && curTemp < 40) { |
| | | max = curTemp; |
| | | } |
| | | if (curTemp < min && curTemp > 3) { |
| | | min = curTemp; |
| | | } |
| | | if(curTemp > 3 && curTemp < 40){ |
| | | sumT += curTemp; |
| | | if (curTemp > max) { |
| | | max = curTemp; |
| | | } |
| | | if (curTemp < min) { |
| | | min = curTemp; |
| | | } |
| | | sumNum++; |
| | | } |
| | | } |
| | | |
| | |
| | | outPut.setTemperature(temperature); |
| | | outPut.setAvgTemperature(NumberUtil.keepPrecision((sumT / sumNum), 1) + ""); |
| | | outPut.setMinTemperature(min + ""); |
| | | outPut.setMaxTemperature(min + ""); |
| | | outPut.setMaxTemperature(max + ""); |
| | | |
| | | |
| | | JSONObject properties = new JSONObject(); |
| | |
| | | GrainOutPut outPut = new GrainOutPut(); |
| | | |
| | | |
| | | double max = ReMessageBuilder.MAX_TEMP, min = ReMessageBuilder.MIN_TEMP, sumT = 0.0, sumNum = cableData.getSumNum(); |
| | | double max = ReMessageBuilder.MAX_TEMP, min = ReMessageBuilder.MIN_TEMP, sumT = 0.0, sumNum =0; |
| | | |
| | | List<GrainTemp> temperature = new ArrayList<>(); |
| | | //根号 |
| | |
| | | temperature.add(new GrainTemp(cableNum + "", z + "", curTemp + "", position + "")); |
| | | |
| | | //求最大最小值 |
| | | if (curTemp < -900) { |
| | | sumNum--; |
| | | } else { |
| | | // if (curTemp < -900) { |
| | | // sumNum--; |
| | | // } else { |
| | | // sumT += curTemp; |
| | | // if (curTemp > max) { |
| | | // max = curTemp; |
| | | // } |
| | | // if (curTemp < min) { |
| | | // min = curTemp; |
| | | // } |
| | | // } |
| | | if (curTemp > max && curTemp < 40) { |
| | | max = curTemp; |
| | | } |
| | | if (curTemp < min && curTemp > 3) { |
| | | min = curTemp; |
| | | } |
| | | if(curTemp > 3 && curTemp < 40){ |
| | | sumT += curTemp; |
| | | if (curTemp > max) { |
| | | max = curTemp; |
| | | } |
| | | if (curTemp < min) { |
| | | min = curTemp; |
| | | } |
| | | sumNum++; |
| | | } |
| | | } |
| | | |
| | |
| | | int cableY = cableData.getCableY(); |
| | | int cableX = cableData.getCableX(); |
| | | |
| | | int sumNum = temps.size(); |
| | | int sumNum = 0; |
| | | |
| | | //数据封装 |
| | | GrainData grain = new GrainData(); |
| | |
| | | temperature.add(new GrainTemp(cableNum + "", z + "", curTemp + "", position + "")); |
| | | |
| | | //求最大最小值 |
| | | if (curTemp < -900) { |
| | | sumNum--; |
| | | } else { |
| | | // if (curTemp < -900) { |
| | | // sumNum--; |
| | | // } else { |
| | | // sumT += curTemp; |
| | | // if (curTemp > max) { |
| | | // max = curTemp; |
| | | // } |
| | | // if (curTemp < min) { |
| | | // min = curTemp; |
| | | // } |
| | | // } |
| | | if (curTemp > max && curTemp < 40) { |
| | | max = curTemp; |
| | | } |
| | | if (curTemp < min && curTemp > 3) { |
| | | min = curTemp; |
| | | } |
| | | if(curTemp > 3 && curTemp < 40){ |
| | | sumT += curTemp; |
| | | if (curTemp > max) { |
| | | max = curTemp; |
| | | } |
| | | if (curTemp < min) { |
| | | min = curTemp; |
| | | } |
| | | sumNum++; |
| | | } |
| | | } |
| | | |
| | |
| | | outPut.setTemperature(temperature); |
| | | outPut.setAvgTemperature(NumberUtil.keepPrecision((sumT / sumNum), 1) + ""); |
| | | outPut.setMinTemperature(min + ""); |
| | | outPut.setMaxTemperature(min + ""); |
| | | outPut.setMaxTemperature(max + ""); |
| | | |
| | | |
| | | JSONObject properties = new JSONObject(); |
| | |
| | | GrainOutPut outPut = new GrainOutPut(); |
| | | |
| | | |
| | | double max = ReMessageBuilder.MAX_TEMP, min = ReMessageBuilder.MIN_TEMP, sumT = 0.0, sumNum = cableData.getSumNum(); |
| | | double max = ReMessageBuilder.MAX_TEMP, min = ReMessageBuilder.MIN_TEMP, sumT = 0.0, sumNum = 0; |
| | | |
| | | List<GrainTemp> temperature = new ArrayList<>(); |
| | | //根号 |
| | |
| | | temperature.add(new GrainTemp(cableNum + "", z + "", curTemp + "", position + "")); |
| | | |
| | | //求最大最小值 |
| | | if (curTemp < -900) { |
| | | sumNum--; |
| | | } else { |
| | | // if (curTemp < -900) { |
| | | // sumNum--; |
| | | // } else { |
| | | // sumT += curTemp; |
| | | // if (curTemp > max) { |
| | | // max = curTemp; |
| | | // } |
| | | // if (curTemp < min) { |
| | | // min = curTemp; |
| | | // } |
| | | // } |
| | | if (curTemp > max && curTemp < 40) { |
| | | max = curTemp; |
| | | } |
| | | if (curTemp < min && curTemp > 3) { |
| | | min = curTemp; |
| | | } |
| | | if(curTemp > 3 && curTemp < 40){ |
| | | sumT += curTemp; |
| | | if (curTemp > max) { |
| | | max = curTemp; |
| | | } |
| | | if (curTemp < min) { |
| | | min = curTemp; |
| | | } |
| | | sumNum++; |
| | | } |
| | | } |
| | | |
| | |
| | | outPut.setTemperature(temperature); |
| | | outPut.setAvgTemperature(NumberUtil.keepPrecision((sumT / sumNum), 1) + ""); |
| | | outPut.setMinTemperature(min + ""); |
| | | outPut.setMaxTemperature(min + ""); |
| | | outPut.setMaxTemperature(max + ""); |
| | | List<GrainTH> ths = new ArrayList<>(); |
| | | |
| | | |