From 06dcd31d599e24711d609dece7eb07a8b5f58dcd Mon Sep 17 00:00:00 2001 From: 潘志宝 <979469083@qq.com> Date: 星期三, 25 六月 2025 10:18:04 +0800 Subject: [PATCH] 测点当前值增加上下限制 --- iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/collection/PointCollector.java | 47 +++++++++++++++++++++++++++++------------------ 1 files changed, 29 insertions(+), 18 deletions(-) diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/collection/PointCollector.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/collection/PointCollector.java index c7475c9..72a0989 100644 --- a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/collection/PointCollector.java +++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/collection/PointCollector.java @@ -6,8 +6,7 @@ import com.iailab.module.data.influxdb.pojo.InfluxPointValueBoolPOJO; import com.iailab.module.data.influxdb.pojo.InfluxPointValueDigPOJO; import com.iailab.module.data.influxdb.pojo.InfluxPointValueSimPOJO; -import com.iailab.module.data.point.collection.handler.CalculateHandle; -import com.iailab.module.data.point.collection.handler.CumulateHandle; +import com.iailab.module.data.point.collection.handler.*; import com.iailab.module.data.point.common.PointTypeEnum; import com.iailab.module.data.point.dto.DaPointDTO; import com.iailab.module.data.point.service.DaPointCollectStatusService; @@ -15,8 +14,6 @@ import com.iailab.module.data.influxdb.pojo.InfluxPointValuePOJO; import com.iailab.module.data.channel.modbus.collector.ModBusCollector; import com.iailab.module.data.channel.opcua.collector.OpcUaCollector; -import com.iailab.module.data.point.collection.handler.ConstantHandle; -import com.iailab.module.data.point.collection.handler.MeasureHandle; import com.iailab.module.data.point.dto.DaPointWriteValueDTO; import com.iailab.module.data.influxdb.service.InfluxDBService; import lombok.extern.slf4j.Slf4j; @@ -30,6 +27,7 @@ import java.math.BigDecimal; import java.util.*; +import java.util.concurrent.TimeUnit; /** * @author PanZhibao @@ -67,15 +65,18 @@ @Resource private CumulateHandle cumulateHandle; + @Resource + private ExtremalHandle extremalHandle; + @Autowired private DaPointCollectStatusService daPointCollectStatusService; @Autowired private RedisTemplate<String, Object> redisTemplate; - public static final String PV = "PV_"; + public static final String PV = "point_value:"; - public static final int offset = 60 * 3; + public static final long offset = 30L; /** * 采集 @@ -85,43 +86,51 @@ */ public void collect(Date collectTime, String minfreq) { try { + log.info("collectTime=" + collectTime.getTime()); Map<String, Object> dataMap = new HashMap<>(); List<InfluxPointValuePOJO> pointValues = new ArrayList<>(); - + // 记录点位状态 + List<String> listGood = new ArrayList<>(); + List<String> listBad = new ArrayList<>(); log.info("读取常量点"); List<DaPointDTO> pointConstantList = daPointService.getConstantPoint(minfreq); - pointValues.addAll(constantHandle.handle(collectTime, pointConstantList, dataMap)); + pointValues.addAll(constantHandle.handle(collectTime, pointConstantList, dataMap, listGood, listBad)); log.info("读取测量点"); List<DaPointDTO> pointMeasureList = daPointService.getMeasurePoint(minfreq); - pointValues.addAll(measureHandle.handle(collectTime, pointMeasureList, dataMap)); - - log.info("读取计算点"); - List<DaPointDTO> pointCalculateList = daPointService.getMathPoint(minfreq); - pointValues.addAll(calculateHandle.handle(collectTime, pointCalculateList, dataMap)); + pointValues.addAll(measureHandle.handle(collectTime, pointMeasureList, dataMap, listGood, listBad)); log.info("读取累计点"); List<DaPointDTO> pointCumulateList = daPointService.getCumulatePoint(minfreq); - pointValues.addAll(cumulateHandle.handle(collectTime, pointCumulateList)); + pointValues.addAll(cumulateHandle.handle(collectTime, pointCumulateList, dataMap, listGood, listBad)); + + log.info("读取极值点"); + List<DaPointDTO> pointExtremalList = daPointService.getExtremalPoint(minfreq); + pointValues.addAll(extremalHandle.handle(collectTime, pointExtremalList, dataMap, listGood, listBad)); + + log.info("读取计算点"); + List<DaPointDTO> pointCalculateList = daPointService.getMathPoint(minfreq); + pointValues.addAll(calculateHandle.handle(collectTime, pointCalculateList, dataMap, listGood, listBad)); log.info("存入时序库"); + log.info("pointValueTimestamp=" + (pointValues.get(0) == null ? 0 : pointValues.get(0).getTimestamp().getNano())); influxDBService.asyncWritePointValues(pointValues); log.info("存入缓存"); for (InfluxPointValuePOJO pointValue : pointValues) { if (pointValue instanceof InfluxPointValueSimPOJO) { InfluxPointValueSimPOJO simPOJO = (InfluxPointValueSimPOJO) pointValue; - redisTemplate.opsForValue().set(PV + simPOJO.getPoint(), simPOJO.getValue(), offset); + redisTemplate.opsForValue().set(PV + simPOJO.getPoint(), simPOJO.getValue().doubleValue(), offset, TimeUnit.SECONDS); } else if (pointValue instanceof InfluxPointValueDigPOJO) { InfluxPointValueDigPOJO digPOJO = (InfluxPointValueDigPOJO) pointValue; - redisTemplate.opsForValue().set(PV + digPOJO.getPoint(), digPOJO.getValue(), offset); + redisTemplate.opsForValue().set(PV + digPOJO.getPoint(), digPOJO.getValue().intValue(), offset, TimeUnit.SECONDS); } else if (pointValue instanceof InfluxPointValueBoolPOJO) { InfluxPointValueBoolPOJO boolPOJO = (InfluxPointValueBoolPOJO) pointValue; - redisTemplate.opsForValue().set(PV + boolPOJO.getPoint(), boolPOJO.getValue(), offset); + redisTemplate.opsForValue().set(PV + boolPOJO.getPoint(), boolPOJO.getValue().booleanValue(), offset, TimeUnit.SECONDS); } } log.info("更新采集状态"); - daPointCollectStatusService.recordStatusList(pointValues, collectTime); + daPointCollectStatusService.recordStatusList(listGood, listBad, collectTime); log.info("采集完成"); } catch (Exception ex) { log.info("采集异常!"); @@ -139,8 +148,10 @@ data.putAll(measureHandle.getCurrent(pointNos)); data.putAll(calculateHandle.getCurrent(pointNos)); data.putAll(cumulateHandle.getCurrent(pointNos)); + data.putAll(extremalHandle.getCurrent(pointNos)); return data; } catch (Exception ex) { + ex.printStackTrace(); return R.error(ex.getMessage()); } -- Gitblit v1.9.3