| | |
|---|
| | | */ |
|---|
| | | private void processMultipleValueDataStream(List<DeviceMqttVO> dataList, String dataStream,int maxSize,Double minVal){ |
|---|
| | | // 筛选出当前数据流对应的数据 |
|---|
| | | // Double value = Double.parseDouble(getValueByDataStream(dataList, dataStream)); |
|---|
| | | Double value = BigDecimal.valueOf(Math.random()*100).setScale(7, RoundingMode.HALF_EVEN).doubleValue(); |
|---|
| | | Double value = Double.parseDouble(getValueByDataStream(dataList, dataStream)); |
|---|
| | | // Double value = BigDecimal.valueOf(Math.random()*100).setScale(7, RoundingMode.HALF_EVEN).doubleValue(); |
|---|
| | | //如果最小值不为空且不为-1，获取到的值小于最小值则跳过不做处理 |
|---|
| | | if(Objects.nonNull(minVal)&&minVal!=-1&&value<minVal){ |
|---|
| | | return; |
|---|
