风机功率风速分析 接口

runeconomy-xk/src/main/java/com/gyee/runeconomy/controller/agc/SpeedPowerAnalysis.java

@@ -0,0 +1,22 @@
+package com.gyee.runeconomy.controller.agc;
+
+import com.gyee.common.model.PointData;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+/**
+ * @author hlf
+ * @date 2025/2/21 11:44
+ * 文件说明：
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class SpeedPowerAnalysis {
+    private List<Double> windSpeed;
+    private List<Double> theoreticalPower;
+    private List<Double> actuatedPower;
+}

runeconomy-xk/src/main/java/com/gyee/runeconomy/mapper/auto/PointInfoMapper.java

@@ -0,0 +1,17 @@
+package com.gyee.runeconomy.mapper.auto;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.gyee.runeconomy.model.auto.PointInfo;
+
+/**
+ * <p>
+ * Mapper 接口
+ * </p>
+ *
+ * @author gfhd
+ * @since 2024-03-01
+ */
+
+public interface PointInfoMapper extends BaseMapper<PointInfo> {
+
+}

runeconomy-xk/src/main/java/com/gyee/runeconomy/model/StatusTime.java

@@ -0,0 +1,21 @@
+package com.gyee.runeconomy.model;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.Date;
+
+/**
+ * @author hlf
+ * @date 2025/2/21 18:30
+ * 文件说明：
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class StatusTime {
+    private String status;
+    private String time;
+    private String name;
+}

runeconomy-xk/src/main/java/com/gyee/runeconomy/model/auto/PointData.java

@@ -0,0 +1,42 @@
+package com.gyee.runeconomy.model.auto;
+
+import lombok.Data;
+
+/**
+ * 测点数据
+ */
+@Data
+public class PointData {
+    /**
+     * 时间戳
+     */
+    private long ts;
+    private String tagName;
+    /**
+     * 数据
+     */
+    private double doubleValue;
+    /**
+     * boolean 数据
+     */
+    private boolean booleanValue;
+
+    private long longValue;
+
+    public PointData() {
+    }
+
+    public PointData(long ts, double doubleValue) {
+        this.ts = ts;
+        this.doubleValue = doubleValue;
+    }
+
+    public double getValue() {
+        if (booleanValue) {
+            return 1;
+        } else if (longValue != 0) {
+            doubleValue = longValue;
+        }
+        return doubleValue;
+    }
+}

runeconomy-xk/src/main/java/com/gyee/runeconomy/model/auto/PointInfo.java

@@ -0,0 +1,42 @@
+package com.gyee.runeconomy.model.auto;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * <p>
+ *
+ * </p>
+ *
+ * @author gfhd
+ * @since 2024-03-01
+ */
+@Data
+@TableName("point_info")
+public class PointInfo implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+    private Double coef;
+    private String lineId;
+    private String name;
+    private String pointKey;
+    private String projectId;
+    private String stationId;
+    private String turbineId;
+    private String uniformCode;
+    private String institutionType;
+    private String spare;
+    private String boosterId;
+    private Double spare2;
+    @TableField(exist = false)
+    private List<PointData> pointDatas;
+}

runeconomy-xk/src/main/java/com/gyee/runeconomy/service/auto/IPointInfoService.java

@@ -0,0 +1,19 @@
+package com.gyee.runeconomy.service.auto;
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.gyee.runeconomy.model.auto.PointInfo;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 服务类
+ * </p>
+ *
+ * @author gfhd
+ * @since 2024-03-01
+ */
+public interface IPointInfoService extends IService<PointInfo> {
+    List<PointInfo> getByEntity(PointInfo pointInfo);
+}

runeconomy-xk/src/main/java/com/gyee/runeconomy/service/auto/impl/PointInfoServiceImpl.java

@@ -0,0 +1,56 @@
+package com.gyee.runeconomy.service.auto.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.gyee.runeconomy.mapper.auto.PointInfoMapper;
+import com.gyee.runeconomy.model.auto.PointInfo;
+import com.gyee.runeconomy.service.auto.IPointInfoService;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 服务实现类
+ * </p>
+ *
+ * @author gfhd
+ * @since 2024-03-01
+ */
+@Service
+//@DataSource(DataSourceType.SLAVE)
+public class PointInfoServiceImpl extends ServiceImpl<PointInfoMapper, PointInfo> implements IPointInfoService {
+
+    @Override
+    @Cacheable(value = "pointinfo", key = "#pointInfo.institutionType + ':' + #pointInfo.stationId + ':' + #pointInfo.projectId + ':' + #pointInfo.lineId + ':' + #pointInfo.turbineId + ':' + #pointInfo.uniformCode")
+    public List<PointInfo> getByEntity(PointInfo pointInfo) {
+        LambdaQueryWrapper<PointInfo> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(pointInfo.getInstitutionType() != null, PointInfo::getInstitutionType, pointInfo.getInstitutionType());
+        if (pointInfo.getTurbineId() != null) {
+            if ("all".equals(pointInfo.getTurbineId()))
+                wrapper.ne(PointInfo::getTurbineId, "");
+            else
+                wrapper.eq(PointInfo::getTurbineId, pointInfo.getTurbineId());
+        } else if (pointInfo.getLineId() != null) {
+            if ("all".equals(pointInfo.getLineId()))
+                wrapper.ne(PointInfo::getLineId, "").eq(PointInfo::getTurbineId, "");
+            else
+                wrapper.eq(PointInfo::getLineId, pointInfo.getLineId());
+        } else if (pointInfo.getProjectId() != null) {
+            if ("all".equals(pointInfo.getProjectId()))
+                wrapper.ne(PointInfo::getProjectId, "").eq(PointInfo::getLineId, "")
+                        .eq(PointInfo::getTurbineId, "");
+            else
+                wrapper.eq(PointInfo::getProjectId, pointInfo.getProjectId());
+        } else if (pointInfo.getStationId() != null) {
+            if ("all".equals(pointInfo.getStationId()))
+                wrapper.ne(PointInfo::getStationId, "").eq(PointInfo::getProjectId, "")
+                        .eq(PointInfo::getLineId, "").eq(PointInfo::getTurbineId, "");
+            else
+                wrapper.eq(PointInfo::getStationId, pointInfo.getStationId());
+        }
+        wrapper.eq(pointInfo.getUniformCode() != null, PointInfo::getUniformCode, pointInfo.getUniformCode());
+        return baseMapper.selectList(wrapper);
+    }
+}