增加AGC接口

runeconomy-xk/src/main/java/com/gyee/runeconomy/config/GyeeConfig.java

@@ -52,6 +52,9 @@ public class GyeeConfig {
      **/
     @Value("${powerCurveFitting.fitting}")
     private String filePathFitting;
+    /** 配置文件路径 **/
+    @Value("${powerCurveFitting.file-path-power}")
+    private String filePathPower;
     /**
      * 数据压缩下载
      **/
@@ -61,6 +64,11 @@ public class GyeeConfig {
      **/
     private String points;
 
+    /**
+     * 数据是否离线执行
+     **/
+    private boolean offLine;
+
 //    public List<String> getPoints() {
 //        if (null == points) {
 //            return Collections.emptyList();
@@ -81,6 +89,14 @@ public class GyeeConfig {
         return codes;
     }
 
+    public String getFilePathPower() {
+        return jarF.getParentFile().getAbsolutePath() + File.separator + filePathPower;
+    }
+
+    public void setFilePathPower(String filePathPower) {
+        this.filePathPower = filePathPower;
+    }
+
     public String getFilePathPrepare() {
         return jarF.getParentFile().getAbsolutePath() + "\\" + filePathPrepare;
     }

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

@@ -0,0 +1,22 @@
+package com.gyee.runeconomy.controller.agc;
+
+import lombok.Data;
+
+@Data
+public class AgcDeviateConfig {
+
+    private String id;
+    /**
+     * 装机容量
+     */
+    private float installedCapacity;
+    /**
+     * 场站名称
+     */
+    private String title;
+
+    private AiPoints power;
+
+    private AiPoints[] aiPoints;
+
+  }

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

@@ -0,0 +1,61 @@
+package com.gyee.runeconomy.controller.agc;
+
+
+import com.gyee.runeconomy.config.GyeeConfig;
+import com.gyee.runeconomy.service.agc.AgcDeviateService;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ * 获取各个场站AGC偏差分析数据
+ */
+@RestController
+@RequestMapping("/agc")
+public class AgcDeviateController {
+    @Resource
+    private AgcDeviateService agcDeviateService;
+    @Resource
+    private GyeeConfig gyeeConfig;
+
+    /**
+     * 获取偏差信息
+     *
+     * @param startTs  开始时间
+     * @param endTs    结束时间
+     * @param id       场站id
+     * @param interval 时间间隔
+     * @return
+     */
+    @GetMapping("/deviate")
+    public Map<String, AgcDeviateTag> getData(@RequestParam(value = "startTs") long startTs,
+                                              @RequestParam(value = "endTs") long endTs,
+                                              @RequestParam(value = "id") String id,
+                                              @RequestParam(value = "interval", defaultValue = "60", required = false) int interval) {
+        List<AgcDeviateTag> ls = new ArrayList<>();
+        if (gyeeConfig.isOffLine()) {
+            ls = agcDeviateService.getAgcDeviateTags(id, startTs, endTs, interval);
+        } else {
+            ls = agcDeviateService.getAgcDeviateTags(id, startTs, endTs, interval);
+        }
+        return ls.stream().collect(Collectors.toMap(AgcDeviateTag::getName, f -> f));
+    }
+
+    /**
+     * 获取配置
+     *
+     * @return
+     */
+    @GetMapping("/config")
+    public Object getAgcConifg() {
+        return agcDeviateService.getConfig();
+    }
+}

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

@@ -0,0 +1,35 @@
+package com.gyee.runeconomy.controller.agc;
+
+import com.gyee.runeconomy.util.realtimesource.feign.TsDoubleTsData;
+
+import java.util.List;
+
+/**
+ * agc曲线偏差数据
+ */
+public class AgcDeviateTag {
+    /**
+     * 数据点名称
+     */
+    private String name;
+    /**
+     * 数据值列表
+     */
+    private List<TsDoubleTsData> values;
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public List<TsDoubleTsData> getValues() {
+        return values;
+    }
+
+    public void setValues(List<TsDoubleTsData> values) {
+        this.values = values;
+    }
+}

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

@@ -0,0 +1,56 @@
+package com.gyee.runeconomy.controller.agc;
+
+/**
+ * 从数据库的value里面取到需要的值
+ */
+public class AiPoints {
+
+    private String name;
+    /**
+     * 标签点
+     */
+    private String tag;
+    /**
+     * 倍率
+     */
+    private float multiplier;
+    /**
+     * 单位
+     */
+    private String unit;
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        if (name == null) {
+            return;
+        }
+        this.name = name.replaceAll("：","");
+    }
+
+    public String getTag() {
+        return tag;
+    }
+
+    public void setTag(String tag) {
+        this.tag = tag;
+    }
+
+    public float getMultiplier() {
+        return multiplier;
+    }
+
+    public void setMultiplier(float multiplier) {
+        this.multiplier = multiplier;
+    }
+
+    public String getUnit() {
+        return unit;
+    }
+
+    public void setUnit(String unit) {
+        this.unit = unit;
+    }
+}

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

@@ -0,0 +1,109 @@
+package com.gyee.runeconomy.controller.agc;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.TypeReference;
+import org.springframework.stereotype.Component;
+
+import java.io.*;
+import java.lang.reflect.Type;
+
+/**
+ * 配置文件读取
+ *
+ * @author xysn
+ */
+@Component
+public class FileService {
+    /**
+     * 从json格式文件中获取对象
+     *
+     * @param path 文件路径
+     * @param type 对象类型
+     * @param <T>  泛型
+     * @return 返回对象
+     */
+    public <T> T getFromFile(String path, Type type) {
+        String str = getStringFormFile(path);
+        return JSON.parseObject(str, type);
+    }
+
+    /**
+     * 从json格式文件中获取对象
+     *
+     * @param path 文件路径
+     * @param type 对象类型
+     * @param <T>  泛型
+     * @return 返回对象
+     */
+    public <T> T getFromFile(String path, TypeReference<T> type) {
+        String str = getStringFormFile(path);
+        return JSON.parseObject(str, type);
+    }
+
+    /**
+     * 从文件中获取字符串
+     *
+     * @param path 路径
+     * @return 字符串
+     */
+    public String getStringFormFile(String path) {
+        BufferedReader bufferedReader = null;
+        File file = new File(path);
+        if (!file.exists()) {
+            return "";
+        }
+        try {
+            bufferedReader = new BufferedReader(new FileReader(file));
+            StringBuilder sb = new StringBuilder();
+            String s = null;
+            while ((s = bufferedReader.readLine()) != null) {
+                sb.append(s);
+            }
+            return sb.toString();
+        } catch (IOException e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                assert bufferedReader != null;
+                bufferedReader.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        return "";
+    }
+
+    /**
+     * 保存对象到文件中
+     *
+     * @param path 文件路径
+     * @param obj  要保存的对象
+     * @return 是否保存成功
+     */
+    public boolean saveObjectToFile(String path, Object obj) {
+        BufferedWriter bufferedWriter = null;
+        try {
+            File file = new File(path);
+            bufferedWriter = new BufferedWriter(new FileWriter(file));
+            String str = "";
+            if (obj instanceof String) {
+                str = obj.toString();
+            } else {
+                str = JSON.toJSONString(obj);
+            }
+            bufferedWriter.write(str);
+            bufferedWriter.flush();
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                assert bufferedWriter != null;
+                bufferedWriter.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        return false;
+    }
+}

runeconomy-xk/src/main/java/com/gyee/runeconomy/dto/AgcDeviateModel.java

@@ -0,0 +1,93 @@
+package com.gyee.runeconomy.dto;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import org.springframework.data.annotation.Id;
+
+//import javax.persistence.Column;
+//import javax.persistence.Id;
+
+@TableName("controlsettings")
+public class AgcDeviateModel extends Model<AgcDeviateModel> {
+    /**
+     * 唯一ID
+     */
+    @Id
+//    @Column(name = "ID")
+    private String id;
+    /**
+     * key
+     */
+//    @Column(name = "KEY")
+    private String key;
+    /**
+     * 时间戳
+     */
+//    @Column(name = "TIMESTAMP")
+    private Long timestamp;
+    /**
+     * 说明，描述
+     */
+//    @Column(name = "DESCRIPTION")
+    private String description;
+    /**
+     * 值
+     */
+//    @Column(name = "VALUE")
+    private String value;
+
+    /**
+     * 是否是备份
+     */
+//    @Column(name = "BACKUP")
+    private boolean backup;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getKey() {
+        return key;
+    }
+
+    public void setKey(String key) {
+        this.key = key;
+    }
+
+    public Long getTimestamp() {
+        return timestamp;
+    }
+
+    public void setTimestamp(Long timestamp) {
+        this.timestamp = timestamp;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+
+    public String getValue() {
+        return value;
+    }
+
+    public void setValue(String value) {
+        this.value = value;
+    }
+
+    public boolean getBackup() {
+        return backup;
+    }
+
+    public void setBackup(boolean backup) {
+        this.backup = backup;
+    }
+
+}

runeconomy-xk/src/main/java/com/gyee/runeconomy/init/CacheContext.java

@@ -5,6 +5,8 @@ import com.alibaba.fastjson.TypeReference;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.gyee.common.model.StringUtils;
 import com.gyee.runeconomy.config.GyeeConfig;
+import com.gyee.runeconomy.controller.agc.AgcDeviateConfig;
+import com.gyee.runeconomy.controller.agc.FileService;
 import com.gyee.runeconomy.model.TemperatureInfo;
 import com.gyee.runeconomy.model.auto.*;
 import com.gyee.runeconomy.service.auto.*;
@@ -16,6 +18,7 @@ import org.springframework.boot.CommandLineRunner;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
+import java.io.File;
 import java.math.BigDecimal;
 import java.time.LocalDate;
 import java.time.temporal.TemporalAdjusters;
@@ -87,7 +90,8 @@ public class CacheContext implements CommandLineRunner {
 
     @Resource
     private ITemperatureinfoService iTemperatureinfoService;
-
+    @Resource
+    private FileService fileService;
 
     @Resource
     GyeeConfig config;
@@ -187,6 +191,11 @@ public class CacheContext implements CommandLineRunner {
 
     public static Map<String, List<ProBasicModelPower>> modelPowerDetailNewMap = new HashMap<>();
 
+    /**
+     * AGC信息缓存
+     */
+    public static Map<String, AgcDeviateConfig> agcDeviateConfigMap= new HashMap<>();
+    public static Map<String, List<String>> files = new HashMap<>();
 
     @Override
     public void run(String... args) throws Exception {
@@ -680,6 +689,7 @@ public class CacheContext implements CommandLineRunner {
 
         cacheNewModelPower();
         cacheNewPoints();
+        cacheAGC();
         initTemperatureInfo();
 
         logger.info("缓存结束------------------------------------------------------------");
@@ -697,7 +707,34 @@ public class CacheContext implements CommandLineRunner {
         wpls.stream().forEach(d -> list.addAll(proBasicEquipmentPointService.selectList(d.getId(), config.getPoints())));
         pointNewMap.putAll(list.stream().collect(Collectors.groupingBy(u -> u.getWindturbineId())));
     }
+    private void cacheAGC(){
+
+        AgcDeviateConfig[] adcs = fileService.getFromFile(config.getFilePathPower() + "agc_info_net.json", AgcDeviateConfig[].class);
+        initFiles();
+        for (AgcDeviateConfig adc : adcs) {
+            agcDeviateConfigMap.put(adc.getId(), adc);
+        }
+    }
 
+    private void initFiles() {
+        files = new HashMap<>();
+        File f = new File(config.getFilePathPower() );
+        File[] fs = f.listFiles();
+        for (File v : fs) {
+            if (v.isDirectory()) {
+                continue;
+            }
+            String[] nm = v.getName().split(",");
+            if (nm.length < 1) {
+                continue;
+            }
+            String name = nm[0];
+            if (!files.containsKey(name)) {
+                files.put(name, new ArrayList<>());
+            }
+            files.get(name).add(v.getPath());
+        }
+    }
     private void initTemperatureInfo() {
         Map<String, TemperatureInfo> tis = new HashMap<>();
 //        Map<String, StationStatus> ssm = getStationStatusMap();

runeconomy-xk/src/main/java/com/gyee/runeconomy/mapper/AgcDeviateMapper.java

@@ -0,0 +1,12 @@
+package com.gyee.runeconomy.mapper;
+
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.gyee.runeconomy.dto.AgcDeviateModel;
+import org.apache.ibatis.annotations.Mapper;
+
+
+@Mapper
+public interface AgcDeviateMapper extends BaseMapper<AgcDeviateModel> {
+
+}

runeconomy-xk/src/main/java/com/gyee/runeconomy/service/agc/AgcDeviateService.java

@@ -0,0 +1,224 @@
+package com.gyee.runeconomy.service.agc;
+
+
+import cn.hutool.core.lang.TypeReference;
+import com.gyee.runeconomy.config.GyeeConfig;
+import com.gyee.runeconomy.controller.agc.AgcDeviateTag;
+import com.gyee.runeconomy.controller.agc.AiPoints;
+import com.gyee.runeconomy.controller.agc.FileService;
+import com.gyee.runeconomy.init.CacheContext;
+import com.gyee.runeconomy.util.realtimesource.feign.IDataAdapter;
+import com.gyee.runeconomy.util.realtimesource.feign.RemoteServiceBuilder;
+import com.gyee.runeconomy.util.realtimesource.feign.TsDoubleTsData;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.system.ApplicationHome;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.io.File;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Optional;
+import java.util.stream.Collectors;
+
+/**
+ * 读取数据库配置文件
+ */
+@Order(0)
+@Component
+public class AgcDeviateService {
+
+    /**
+     * 是否是离线版本
+     */
+    private boolean isOffline;
+
+    /**
+     * 离线数据保存路径
+     */
+    private String filePathPower = "data\\power\\";
+
+    public File jarF = null;
+
+    {
+        ApplicationHome h = new ApplicationHome(getClass());
+        jarF = h.getSource();
+    }
+
+    /**
+     * 文件读写
+     */
+    private FileService fileService;
+
+
+    @Autowired
+    private GyeeConfig config;
+
+    @Resource
+    private IDataAdapter iDataAdapter;
+    @Autowired
+    private RemoteServiceBuilder remoteService;
+
+    /**
+     * 获取agc曲线偏差分析需要的数据
+     *
+     * @param id       场站ID
+     * @param startTs  开始时间戳
+     * @param endTs    结束时间戳
+     * @param interval 数据时间间隔
+     * @return 分析数据
+     */
+    public List<AgcDeviateTag> getAgcDeviateTags(String id, long startTs, long endTs, int interval) {
+        List<AgcDeviateTag> ladt = new ArrayList<>();
+        List<AiPoints> laps = getAiPoints(id);
+        if (laps == null) {
+            return ladt;
+        }
+        for (AiPoints ap : laps) {
+            AgcDeviateTag adt = new AgcDeviateTag();
+            adt.setName(ap.getName());
+            List<TsDoubleTsData> lpd = getPointData(ap, startTs, endTs, interval);
+            adt.setValues(lpd);
+            ladt.add(adt);
+        }
+        // 上限下限
+        List<AgcDeviateTag> upperLowerLimits = getUpperLowerLimits(ladt, id);
+        ladt.addAll(upperLowerLimits);
+        return ladt;
+    }
+
+    private List<TsDoubleTsData> getPointData(AiPoints ap, long startTs, long endTs, int interval) {
+        List<TsDoubleTsData> lpds = null;
+        if (ap.getTag().contains(",")) {
+            lpds = getMultiple(ap, startTs, endTs, interval);
+        } else {
+
+
+            if (ap.getTag().startsWith("NEM")) {
+                lpds = remoteService.taos().getHistorytsSnap(ap.getTag(), startTs, endTs, interval);
+            } else {
+                lpds = remoteService.adapterfd().getHistorytsSnap(ap.getTag(), startTs, endTs, interval);
+            }
+
+        }
+        if (ap.getMultiplier() != 1) {
+            for (TsDoubleTsData pd : lpds) {
+                pd.setDoubleValue(pd.getDoubleValue() * ap.getMultiplier());
+            }
+        }
+        return lpds;
+    }
+
+    /**
+     * 获取多个标签点数值
+     */
+    private List<TsDoubleTsData> getMultiple(AiPoints ap, long startTs, long endTs, int interval) {
+        String[] tags = ap.getTag().split(",");
+        boolean isFirst = true;
+        List<TsDoubleTsData> lpd = new ArrayList<>();
+        for (String tag : tags) {
+            if (tag.equals("")) {
+                continue;
+            }
+
+            List<TsDoubleTsData> vals = iDataAdapter.getHistorySnap(tag, startTs, endTs, interval);
+            for (int i = 0; i < vals.size(); ++i) {
+                if (isFirst) {
+                    lpd.addAll(vals);
+                    isFirst = false;
+                    break;
+                } else {
+                    TsDoubleTsData pd = lpd.get(i);
+                    pd.setDoubleValue(vals.get(i).getDoubleValue() + pd.getDoubleValue());
+                }
+            }
+        }
+        return lpd;
+    }
+
+    /**
+     * 获取上限下限
+     */
+    private List<AgcDeviateTag> getUpperLowerLimits(List<AgcDeviateTag> ladt, String id) {
+        // 装机容量
+        double capacity = getCapacity(id);
+        // 偏差
+        double deviation = capacity * 0.03;
+        // 有功设定
+        Optional<AgcDeviateTag> agcLimit = ladt.stream().filter(ad -> ad.getName().equals("有功设定限值")).findFirst();
+
+        List<AgcDeviateTag> la = new ArrayList<>();
+        if (!agcLimit.isPresent()) {
+            return la;
+        }
+        AgcDeviateTag adtUper = new AgcDeviateTag();
+        adtUper.setName("偏差上限");
+        adtUper.setValues(new ArrayList<>());
+        AgcDeviateTag adtLimt = new AgcDeviateTag();
+        adtLimt.setName("偏差下限");
+        adtLimt.setValues(new ArrayList<>());
+
+        for (TsDoubleTsData pd : agcLimit.get().getValues()) {
+            long ts = pd.getTs();
+            TsDoubleTsData pdUper = new TsDoubleTsData();
+            pdUper.setTs(ts);
+            pdUper.setDoubleValue(pd.getDoubleValue() * 1.03);
+            TsDoubleTsData pdLimt = new TsDoubleTsData();
+            pdLimt.setTs(ts);
+            pdLimt.setDoubleValue(pd.getDoubleValue() * 0.97);
+            adtUper.getValues().add(pdUper);
+            adtLimt.getValues().add(pdLimt);
+        }
+        la.add(adtUper);
+        la.add(adtLimt);
+        return la;
+    }
+
+
+    /**
+     * 根据ID获取agc配置信息
+     *
+     * @param id 场站ID
+     * @return 配置信息
+     */
+    private List<AiPoints> getAiPoints(String id) {
+        if (!CacheContext.agcDeviateConfigMap.containsKey(id)) {
+            return null;
+        }
+        AiPoints[] aiPoints = CacheContext.agcDeviateConfigMap.get(id).getAiPoints();
+        return Arrays.stream(aiPoints).filter(ap -> ap.getName().contains("功") && !ap.getName().contains("预测")).collect(Collectors.toList());
+    }
+
+    private double getCapacity(String id) {
+        if (!CacheContext.agcDeviateConfigMap.containsKey(id)) {
+            return 0;
+        }
+        return CacheContext.agcDeviateConfigMap.get(id).getInstalledCapacity();
+    }
+
+    /**
+     * 获取配置
+     *
+     * @return
+     */
+    public Object getConfig() {
+        return CacheContext.agcDeviateConfigMap;
+    }
+
+    public List<AgcDeviateTag> getAgcDeviateTagsOffline(String id, long startTs, long endTs, int interval) {
+        if (!CacheContext.files.containsKey(id)) {
+            return new ArrayList<>();
+        }
+        List<String> ls = CacheContext.files.get(id);
+
+        if (ls == null) {
+            return new ArrayList<>();
+        }
+
+        int ran = (int) (Math.random() * ls.size());
+        return fileService.getFromFile(ls.get(ran), new TypeReference<List<AgcDeviateTag>>() {
+        });
+    }
+}

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

@@ -31,7 +31,6 @@ public class ProEconAlarmTypeServiceImpl extends ServiceImpl<ProEconAlarmTypeMap
         if (collect != null || collect.size() > 0) {
             model = collect.get(0).getModelId();
         }
-        model="alertrule_category";
         QueryWrapper<ProEconAlarmType> queryWrapper = new QueryWrapper<>();
         queryWrapper.lambda().eq(ProEconAlarmType::getCategory,model);
         List<ProEconAlarmType> proEconAlarmTypes = baseMapper.selectList(queryWrapper);

runeconomy-xk/src/main/resources/application-nxf.yml

@@ -100,6 +100,8 @@ powerCurveFitting:
   prepare: prepare
   process: process
   fitting: fitting
+  # 功率曲线离线数据保存路径
+  file-path-power: data\power\
 
 #devtools:
 #  restart: