From a40221c883c632630b4876ad846e08c0da8af388 Mon Sep 17 00:00:00 2001
From: Jay <csj123456>
Date: 星期三, 16 十月 2024 09:20:23 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/collection/handler/MeasureHandle.java | 69 +++++++---------------------------
1 files changed, 15 insertions(+), 54 deletions(-)
diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/collection/handler/MeasureHandle.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/collection/handler/MeasureHandle.java
index 44850d5..455b836 100644
--- a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/collection/handler/MeasureHandle.java
+++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/collection/handler/MeasureHandle.java
@@ -1,5 +1,6 @@
package com.iailab.module.data.point.collection.handler;
+import com.iailab.module.data.channel.opcda.collector.OpcDACollector;
import com.iailab.module.data.common.enums.CommonConstant;
import com.iailab.module.data.common.enums.DataSourceType;
import com.iailab.module.data.common.enums.DataTypeEnum;
@@ -11,11 +12,11 @@
import com.iailab.module.data.point.common.PointDataTypeEnum;
import com.iailab.module.data.point.dto.DaPointDTO;
import com.iailab.module.data.point.service.DaPointService;
-import com.iailab.module.data.http.collector.HttpCollectorForZxzk;
-import com.iailab.module.data.http.service.impl.HttpTagCollector;
import com.iailab.module.data.influxdb.pojo.InfluxPointValuePOJO;
import lombok.extern.slf4j.Slf4j;
import javax.annotation.Resource;
+
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
@@ -46,11 +47,8 @@
@Resource
private OpcUaCollector opcUaCollector;
- @Resource
- private HttpTagCollector httpTagCollector;
-
- @Resource
- private HttpCollectorForZxzk httpCollectorForZxzk;
+ @Autowired
+ private OpcDACollector opcDACollector;
@Resource
private DaPointService daPointService;
@@ -62,74 +60,39 @@
return result;
}
- List<String[]> opcuaTagIds = new ArrayList<>();
+ List<String[]> opcUaTagIds = new ArrayList<>();
List<String[]> opcDaTagIds = new ArrayList<>();
List<String[]> modbusTagIds = new ArrayList<>();
List<String[]> kioTagIds = new ArrayList<>();
List<String[]> httpTagZxzk = new ArrayList<>();
- List<String> tagYearPeiIds = new ArrayList<>();
- List<String> tagCurrentPerformanceIds = new ArrayList<>();
- List<String> tagCurrentSaleIds = new ArrayList<>();
- List<String> tagPrdTimeDistIds = new ArrayList<>();
-
dtos.stream().forEach(item -> {
if (DataSourceType.OPCUA.getCode().equals(item.getSourceType())) {
- opcuaTagIds.add(new String[]{item.getSourceId(), item.getTagNo()});
+ opcUaTagIds.add(new String[]{item.getSourceId(), item.getTagNo()});
} else if (DataSourceType.OPCDA.getCode().equals(item.getSourceType())) {
opcDaTagIds.add(new String[]{item.getSourceId(), item.getTagNo()});
} else if (DataSourceType.ModBus.getCode().equals(item.getSourceType())) {
modbusTagIds.add(new String[]{item.getSourceId(), item.getTagNo()});
} else if (DataSourceType.KIO.getCode().equals(item.getSourceType())) {
kioTagIds.add(new String[]{item.getSourceId(), item.getTagNo()});
- } else if (DataSourceType.HTTP.getCode().equals(item.getSourceType())) {
- if (CommonConstant.YEAR_PEI_HTTP_TAG.equals(item.getSourceId())) {
- tagYearPeiIds.add(item.getTagNo());
- } else if (CommonConstant.CURRENT_PERFORMANCE_HTTP_TAG.equals(item.getSourceId())) {
- tagCurrentPerformanceIds.add(item.getTagNo());
- } else if (CommonConstant.CURRENT_SALE_HTTP_TAG.equals(item.getSourceId())) {
- tagCurrentSaleIds.add(item.getTagNo());
- } else if (CommonConstant.PRD_TIME_DIST_HTTP_TAG.equals(item.getSourceId())) {
- tagPrdTimeDistIds.add(item.getTagNo());
- } else if (CommonConstant.HTTP_API_ZXZK_IH.equals(item.getSourceName())) {
- httpTagZxzk.add(new String[]{item.getSourceId(), item.getTagNo()});
- }
}
});
- if (!CollectionUtils.isEmpty(opcuaTagIds)) {
- Map<String, Object> tagValues = opcUaCollector.getTagValues(opcuaTagIds);
- this.toCommonResult(collectTime, dtos, tagValues, dataMap, result);
+ Map<String, Object> tagValues = new HashMap<>();
+ if (!CollectionUtils.isEmpty(opcUaTagIds)) {
+ tagValues.putAll(opcUaCollector.getTagValues(opcUaTagIds));
}
if (!CollectionUtils.isEmpty(opcDaTagIds)) {
+ tagValues.putAll(opcDACollector.getTagValues(modbusTagIds));
}
if (!CollectionUtils.isEmpty(modbusTagIds)) {
- Map<String, Object> tagValues = modBusCollector.getTagValues(modbusTagIds);
- this.toCommonResult(collectTime, dtos, tagValues, dataMap, result);
+ tagValues.putAll(modBusCollector.getTagValues(modbusTagIds));
}
if (!CollectionUtils.isEmpty(kioTagIds)) {
- Map<String, Object> tagValues = kingIOCollector.getTagValues(kioTagIds);
- this.toCommonResult(collectTime, dtos, tagValues, dataMap, result);
+ tagValues.putAll(kingIOCollector.getTagValues(kioTagIds));
}
- if (!CollectionUtils.isEmpty(httpTagZxzk)) {
- Map<String, Object> tagValues = httpCollectorForZxzk.getTagValues(httpTagZxzk);
- this.toCommonResult(collectTime, dtos, tagValues, dataMap, result);
- }
- if (!CollectionUtils.isEmpty(tagYearPeiIds)) {
- Map<String, Object> tagValues = httpTagCollector.collect(CommonConstant.YEAR_PEI_HTTP_TAG, tagYearPeiIds);
- this.toCommonResult(collectTime, dtos, tagValues, dataMap, result);
- } else if (!CollectionUtils.isEmpty(tagCurrentPerformanceIds)) {
- Map<String, Object> tagValues = httpTagCollector.collect(CommonConstant.CURRENT_PERFORMANCE_HTTP_TAG, tagCurrentPerformanceIds);
- this.toCommonResult(collectTime, dtos, tagValues, dataMap, result);
- } else if (!CollectionUtils.isEmpty(tagCurrentSaleIds)) {
- Map<String, Object> tagValues = httpTagCollector.collect(CommonConstant.CURRENT_SALE_HTTP_TAG, tagCurrentSaleIds);
- this.toCommonResult(collectTime, dtos, tagValues, dataMap, result);
- } else if (!CollectionUtils.isEmpty(tagPrdTimeDistIds)) {
- Map<String, Object> tagValues = httpTagCollector.collect(CommonConstant.PRD_TIME_DIST_HTTP_TAG, tagPrdTimeDistIds);
- this.toCommonResult(collectTime, dtos, tagValues, dataMap, result);
- }
-
+ this.toCommonResult(collectTime, dtos, tagValues, dataMap, result);
log.info("测量点处理结束");
return result;
}
@@ -204,9 +167,7 @@
} else if (DataSourceType.KIO.getCode().equals(item.getSourceType())) {
value = kingIOCollector.getTagValue(item.getSourceId(), item.getTagNo());
} else if (DataSourceType.HTTP.getCode().equals(item.getSourceType())) {
- if (CommonConstant.HTTP_API_ZXZK_IH.equals(item.getSourceName())) {
- value = httpCollectorForZxzk.getTagValue(item.getSourceId(), item.getTagNo());
- }
+
} else {
log.info("没有匹配的TagNo=" + item.getTagNo());
}
--
Gitblit v1.9.3