From c84806dc721cedbfd12ff513c05b17ba88b679dd Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期三, 14 五月 2025 15:26:35 +0800
Subject: [PATCH] 极值点处理类
---
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/DaPointServiceImpl.java | 32 ++++++++++++++++++++++++++++++++
1 files changed, 32 insertions(+), 0 deletions(-)
diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/DaPointServiceImpl.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/DaPointServiceImpl.java
index 96220b7..cdb4e2a 100644
--- a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/DaPointServiceImpl.java
+++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/DaPointServiceImpl.java
@@ -61,6 +61,9 @@
@Autowired
private DaSequenceNumService daSequenceNumService;
+
+ @Autowired
+ private DaExtremalPointService daExtremalPointService;
@Resource
private DaPointDao daPointDao;
@@ -108,6 +111,9 @@
break;
case CUMULATE:
result.setCumulatePoint(daCumulatePointService.getByPoint(id));
+ break;
+ case EXTREMAL:
+ result.setExtremalPoint(daExtremalPointService.getByPoint(id));
break;
default:
break;
@@ -182,6 +188,10 @@
daCumulatePointService.add(dataPoint.getCumulatePoint(), daPointEntity.getId());
daPointEntity.setPointNo(daSequenceNumService.getAndIncreaseByCode(IncreaseCodeEnum.POINT_L.name()));
break;
+ case EXTREMAL:
+ daExtremalPointService.add(dataPoint.getExtremalPoint(), daPointEntity.getId());
+ daPointEntity.setPointNo(daSequenceNumService.getAndIncreaseByCode(IncreaseCodeEnum.POINT_E.name()));
+ break;
default:
break;
}
@@ -214,6 +224,9 @@
case CUMULATE:
daCumulatePointService.update(dataPoint.getCumulatePoint());
break;
+ case EXTREMAL:
+ daExtremalPointService.update(dataPoint.getExtremalPoint());
+ break;
default:
break;
}
@@ -228,6 +241,7 @@
daMeasurePointService.deleteByPoint(ids);
daMathPointService.deleteByPoint(ids);
daCumulatePointService.deleteByPoint(ids);
+ daExtremalPointService.deleteByPoint(ids);
// 清空缓存
clearCache();
}
@@ -345,6 +359,24 @@
}
@Override
+ public List<DaPointDTO> getExtremalPoint(String freq) {
+ Map<String, Object> params = new HashMap<>(3);
+ params.put("pointType", PointTypeEnum.CUMULATE.getCode());
+ params.put("isEnable", CommonConstant.IS_ENABLE);
+ params.put("minfreqid", freq);
+ return daPointDao.getExtremalPoint(params);
+ }
+
+ @Override
+ public List<DaPointDTO> getExtremalPoint(List<String> pointNos) {
+ Map<String, Object> params = new HashMap<>(3);
+ params.put("pointType", PointTypeEnum.CUMULATE.getCode());
+ params.put("isEnable", CommonConstant.IS_ENABLE);
+ params.put("pointNos", pointNos);
+ return daPointDao.getExtremalPoint(params);
+ }
+
+ @Override
public List<DaPointDTO> getCumulatePoint(DaPointPageReqVO reqVO) {
Map<String, Object> params = new HashMap<>(3);
params.put("pointType", PointTypeEnum.CUMULATE.getCode());
--
Gitblit v1.9.3