预测功率准确率

realtime/generationXK-service/src/main/java/com/gyee/generation/config/XxlJobConfig.java

@@ -26,7 +26,7 @@ import org.springframework.core.env.Environment;
 //@PropertySource("classpath:xxl-job-executorRG.properties")
 //@PropertySource("classpath:xxl-job-executorJN.properties")
 //
-//@PropertySource("classpath:xxl-job-7001.properties")
+@PropertySource("classpath:xxl-job-accuracy.properties")
 //@PropertySource("classpath:xxl-job-7002.properties")
 //@PropertySource("classpath:xxl-job-7003.properties")
 //@PropertySource("classpath:xxl-job-executorGF001.properties")
@@ -36,20 +36,19 @@ import org.springframework.core.env.Environment;
 //@PropertySource("classpath:xxl-job-executorGF005.properties")
 //@PropertySource("classpath:xxl-job-executorGF006.properties")
 
-@PropertySource("classpath:xxl-job-region.properties")
+//@PropertySource("classpath:xxl-job-region.properties")
 public class XxlJobConfig implements EnvironmentAware {
     private Environment env;
 
 
     @Override
     public void setEnvironment(Environment environment) {
-        this.env=environment;
+        this.env = environment;
     }
 
     private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);
 
 
-
     @Bean
     public XxlJobSpringExecutor xxlJobExecutor() {
         logger.info(">>>>>>>>>>> xxl-job config init.");

realtime/generationXK-service/src/main/java/com/gyee/generation/controller/ProEconStationPowerController.java

@@ -0,0 +1,20 @@
+package com.gyee.generation.controller;
+
+
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * <p>
+ * 预测功率合格 前端控制器
+ * </p>
+ *
+ * @author xieshengjie
+ * @since 2023-09-13
+ */
+@RestController
+@RequestMapping("//pro-econ-station-power")
+public class ProEconStationPowerController {
+
+}

realtime/generationXK-service/src/main/java/com/gyee/generation/mapper/auto/ProEconStationPowerMapper.java

@@ -0,0 +1,16 @@
+package com.gyee.generation.mapper.auto;
+
+import com.gyee.generation.model.auto.ProEconStationPower;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 预测功率合格 Mapper 接口
+ * </p>
+ *
+ * @author xieshengjie
+ * @since 2023-09-13
+ */
+public interface ProEconStationPowerMapper extends BaseMapper<ProEconStationPower> {
+
+}

realtime/generationXK-service/src/main/java/com/gyee/generation/model/auto/ProEconStationPower.java

@@ -0,0 +1,58 @@
+package com.gyee.generation.model.auto;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * <p>
+ * 预测功率合格
+ * </p>
+ *
+ * @author wang
+ * @since 2023-09-13
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class ProEconStationPower extends Model {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 编码
+     */
+    @TableId(value = "id", type = IdType.INPUT)
+    private String id;
+
+    /**
+     * 日期
+     */
+    private Date recordDate;
+
+    /**
+     * 所属风电场
+     */
+    private String windpowerstationId;
+
+    /**
+     * 日96点准确率
+     */
+    private BigDecimal powerAccuracy;
+
+    /**
+     * 日考核分数
+     */
+    private BigDecimal assessmentScore;
+
+    /**
+     * 日发电量预测
+     */
+    private BigDecimal dayPowerForecast;
+
+
+}

realtime/generationXK-service/src/main/java/com/gyee/generation/service/StationPower/StationPowerService.java

@@ -0,0 +1,415 @@
+package com.gyee.generation.service.StationPower;
+
+import com.gyee.common.contant.ContantXk;
+import com.gyee.common.model.PointData;
+import com.gyee.common.model.StringUtils;
+import com.gyee.common.util.SortUtils;
+import com.gyee.generation.init.CacheContext;
+import com.gyee.generation.model.auto.ProBasicPowerstation;
+import com.gyee.generation.model.auto.ProBasicPowerstationPoint;
+import com.gyee.generation.model.auto.ProBasicProject;
+import com.gyee.generation.model.auto.ProEconStationPower;
+import com.gyee.generation.service.auto.impl.ProEconStationPowerServiceImpl;
+import com.gyee.generation.util.math.ShortTermPowerPredictionAccuracyCalculator;
+import com.gyee.generation.util.realtimesource.IEdosUtil;
+import com.gyee.generation.util.realtimesource.timeseries.ForecastVo;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.util.*;
+
+@Service
+public class StationPowerService {
+
+    @Resource
+    private IEdosUtil edosUtil;
+
+    @Resource
+    private ShortTermPowerPredictionAccuracyCalculator shortTermPowerPredictionAccuracyCalculator;
+
+    @Resource
+    private ProEconStationPowerServiceImpl powerService;
+
+    public void predictedPower() throws Exception {
+
+        String type ="F";
+        Map<String, Map<String, ProBasicPowerstationPoint>> linepointmap = CacheContext.linepointmap;
+        Map<String, Map<String, ProBasicPowerstationPoint>> propointmap = CacheContext.propointmap;
+        Map<String, Map<String, ProBasicPowerstationPoint>> wppointmap = CacheContext.wppointmap;
+
+// 获取当前日期
+        Date currentDate = new Date();
+
+// 创建 Calendar 对象，并设置为当前日期
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(currentDate);
+
+// 将时间设为0点
+        calendar.set(Calendar.HOUR_OF_DAY, 0);
+        calendar.set(Calendar.MINUTE, 0);
+        calendar.set(Calendar.SECOND, 0);
+        calendar.set(Calendar.MILLISECOND, 0);
+
+// 设置 beginDate 为当天的0点
+        Date beginDate = calendar.getTime();
+
+// 将时间设为23点59分59秒
+        calendar.set(Calendar.HOUR_OF_DAY, 23);
+        calendar.set(Calendar.MINUTE, 59);
+        calendar.set(Calendar.SECOND, 59);
+        calendar.set(Calendar.MILLISECOND, 999);
+
+// 设置 endDate 为当天的23点59分59秒
+        Date endDate = calendar.getTime();
+
+        String wpId = null;
+
+
+        List<ProBasicProject> pjls = CacheContext.pjls;
+
+        List<ProBasicProject> pjllist = null;
+
+        List<ProBasicPowerstation> wplLs = CacheContext.wpls;
+        SortUtils.sort(wplLs, "orderNum", SortUtils.ASC);
+
+        List<ForecastVo> vos = null;
+        Map<String, Object> map = new LinkedHashMap<>();
+        ProBasicPowerstationPoint ycgl = null;
+        ProBasicPowerstationPoint sjgl = null;
+
+        for (ProBasicPowerstation Wp : wplLs) {
+
+            if (Wp.getId().contains("MLJ"))continue;
+            wpId = Wp.getId();
+
+
+            pjllist = new ArrayList();
+            //得到此循环场站期次
+            for (ProBasicProject pj : pjls) {
+                if (wpId.equals(pj.getWindpowerstationId())) {
+                    pjllist.add(pj);
+                }
+            }
+
+            List<ProBasicPowerstation> station = new ArrayList<>();
+            for (ProBasicPowerstation wp1 : CacheContext.wpls) {
+                if (wpId.equals(wp1.getId())) {
+                    station.add(wp1);
+                }
+            }
+
+            if (wpId.contains("GJY") | wpId.contains("TZ_GDC_STA") | wpId.contains("PTZ_FDC_STA") | wpId.contains("NJL") | wpId.contains("SY")) {
+                for (ProBasicProject wp : pjllist) {
+                    Map<String, ProBasicPowerstationPoint> propointMap = propointmap.get(wp.getId());
+                    List<ForecastVo> vos1 = new ArrayList<>();
+                    List<ForecastVo> vos2 = new ArrayList<>();
+                    List<ForecastVo> vos3 = new ArrayList<>();
+                    List<ForecastVo> vos4 = new ArrayList<>();
+                    List<ForecastVo> vos5 = new ArrayList<>();
+
+                    // 在每次循环开始前将变量置为null
+                    ycgl = null;
+                    sjgl = null;
+
+                    if (wpId.endsWith("FDC_STA") && type.equals("F")) {
+                        ycgl = propointMap.get(ContantXk.ZYCGL);
+                        sjgl = propointMap.get(ContantXk.PJGL15);
+                    }
+                    if (wpId.endsWith("GDC_STA") && type.equals("G")) {
+                        ycgl = propointMap.get(ContantXk.ZYCGL);
+                        sjgl = propointMap.get(ContantXk.PJGL15);
+                    }
+
+                    if (sjgl != null) {
+                        List<PointData> ycglls = edosUtil.getHistoryDatasSnap(ycgl, beginDate.getTime() / 1000, endDate.getTime() / 1000, null, 900L);
+                        List<PointData> sjglls = edosUtil.getHistoryDatasSnap(sjgl, beginDate.getTime() / 1000, endDate.getTime() / 1000, null, 900L);
+
+                        double temp3 = 0;
+                        double temp4 = 0;
+
+                        if (wpId.contains("GJY")) {
+                            for (int i = 0; i < sjglls.size(); i++) {
+                                ForecastVo vo = new ForecastVo();
+                                vo.setSjgl(0.0); //实际功率
+                                vo.setYcgl(0.0); //功率预测
+                                vo.setHours(2023L);  //时间戳
+                                vo.setName(wpId);
+
+                                vo.setHours(sjglls.get(i).getPointTime());
+                                vo.setName("平鲁高家堰风电场");
+
+                                vo.setId(wpId);
+
+                                temp3 = ycglls.get(i).getPointValueInDouble();
+                                vo.setYcgl(StringUtils.round(temp3, 2));
+
+                                temp4 = sjglls.get(i).getPointValueInDouble();
+                                vo.setSjgl(StringUtils.round(temp4 /1000, 2));
+
+                                vos1.add(vo);
+                            }
+                        }
+
+                        if (wpId.contains("TZ_GDC_STA")) {
+                            for (int i = 0; i < sjglls.size(); i++) {
+                                ForecastVo vo2 = new ForecastVo();
+                                vo2.setSjgl(0.0); //实际功率
+                                vo2.setYcgl(0.0); //功率预测
+                                vo2.setHours(2023L);  //时间戳
+                                vo2.setName(wpId);
+
+                                vo2.setHours(sjglls.get(i).getPointTime());
+                                vo2.setName("天镇电站");
+                                vo2.setId(wpId);
+
+                                temp3 = ycglls.get(i).getPointValueInDouble();
+                                vo2.setYcgl(StringUtils.round(temp3, 2));
+
+                                temp4 = sjglls.get(i).getPointValueInDouble();
+                                vo2.setSjgl(StringUtils.round(temp4 /1000, 2));
+
+                                vos2.add(vo2);
+                            }
+                        }
+
+                        if (wpId.contains("PTZ_FDC_STA")) {
+                            for (int i = 0; i < sjglls.size(); i++) {
+                                ForecastVo vo3 = new ForecastVo();
+                                vo3.setSjgl(0.0); //实际功率
+                                vo3.setYcgl(0.0); //功率预测
+                                vo3.setHours(2023L);  //时间戳
+                                vo3.setName(wpId);
+
+                                vo3.setHours(sjglls.get(i).getPointTime());
+
+                                vo3.setName("寿阳平头镇风电场");
+
+                                vo3.setId(wpId);
+
+                                temp3 = ycglls.get(i).getPointValueInDouble();
+                                vo3.setYcgl(StringUtils.round(temp3, 2));
+
+                                temp4 = sjglls.get(i).getPointValueInDouble();
+                                vo3.setSjgl(StringUtils.round(temp4 /1000, 2));
+                                vos3.add(vo3);
+                            }
+                        }
+
+                        if (wpId.contains("NJL")) {
+                            for (int i = 0; i < sjglls.size(); i++) {
+                                ForecastVo vo4 = new ForecastVo();
+                                vo4.setSjgl(0.0); //实际功率
+                                vo4.setYcgl(0.0); //功率预测
+                                vo4.setHours(2023L);  //时间戳
+                                vo4.setName(wpId);
+
+                                vo4.setHours(sjglls.get(i).getPointTime());
+
+                                vo4.setName("朔城牛家岭风电场");
+
+                                vo4.setId(wpId);
+
+                                temp3 = ycglls.get(i).getPointValueInDouble();
+                                vo4.setYcgl(StringUtils.round(temp3, 2));
+
+                                temp4 = sjglls.get(i).getPointValueInDouble();
+                                vo4.setSjgl(StringUtils.round(temp4 /1000, 2));
+                                vos4.add(vo4);
+                            }
+                        }
+
+                        if (wpId.contains("SY")) {
+                            for (int i = 0; i < sjglls.size(); i++) {
+                                ForecastVo vo5 = new ForecastVo();
+                                vo5.setSjgl(0.0); //实际功率
+                                vo5.setYcgl(0.0); //功率预测
+                                vo5.setHours(2023L);  //时间戳
+                                vo5.setName(wpId);
+
+                                vo5.setHours(sjglls.get(i).getPointTime());
+                                vo5.setName("山阴电站");
+                                vo5.setId(wpId);
+
+                                 temp3 = ycglls.get(i).getPointValueInDouble();
+                                vo5.setYcgl(StringUtils.round(temp3, 2));
+
+                                temp4 = sjglls.get(i).getPointValueInDouble();
+                                vo5.setSjgl(StringUtils.round(temp4 /1000, 2));
+
+                                vos5.add(vo5);
+                            }
+                        }
+
+
+                        if (wpId.contains("GJY")) {
+                            if (map.containsKey("SXJ_KGDL_GJYF01_EG")) {
+                                List<ForecastVo> previousVos1 = (List<ForecastVo>) map.get("SXJ_KGDL_GJYF01_EG");
+                                for (int i = 0; i < vos1.size(); i++) {
+                                    ForecastVo previousVo1 = previousVos1.get(i);
+                                    ForecastVo currentVo1 = vos1.get(i);
+
+                                    currentVo1.setSjgl(previousVo1.getSjgl() + currentVo1.getSjgl());
+                                    currentVo1.setYcgl(previousVo1.getYcgl() + currentVo1.getYcgl());
+
+                                }
+                            }
+                        } else if (wpId.contains("TZ_GDC_STA")) {
+                            if (map.containsKey("SXJ_KGDL_TZG01_EG")) {
+                                List<ForecastVo> previousVos1 = (List<ForecastVo>) map.get("SXJ_KGDL_TZG01_EG");
+                                for (int i = 0; i < vos2.size(); i++) {
+                                    ForecastVo previousVo1 = previousVos1.get(i);
+                                    ForecastVo currentVo1 = vos2.get(i);
+
+                                    currentVo1.setSjgl(previousVo1.getSjgl() + currentVo1.getSjgl());
+                                    currentVo1.setYcgl(previousVo1.getYcgl() + currentVo1.getYcgl());
+
+                                }
+                            }
+                        } else if (wpId.contains("SY")) {
+                            if (map.containsKey("SXJ_KGDL_SYG01_EG")) {
+                                List<ForecastVo> previousVos1 = (List<ForecastVo>) map.get("SXJ_KGDL_SYG01_EG");
+                                for (int i = 0; i < vos5.size(); i++) {
+                                    ForecastVo previousVo1 = previousVos1.get(i);
+                                    ForecastVo currentVo1 = vos5.get(i);
+
+                                    currentVo1.setSjgl(previousVo1.getSjgl() + currentVo1.getSjgl());
+                                    currentVo1.setYcgl(previousVo1.getYcgl() + currentVo1.getYcgl());
+
+                                }
+                            }
+                        } else if (wpId.contains("NJL")) {
+                            if (map.containsKey("SXJ_KGDL_NJLF01_EG")) {
+                                List<ForecastVo> previousVos1 = (List<ForecastVo>) map.get("SXJ_KGDL_NJLF01_EG");
+                                for (int i = 0; i < vos4.size(); i++) {
+                                    ForecastVo previousVo1 = previousVos1.get(i);
+                                    ForecastVo currentVo1 = vos4.get(i);
+
+                                    currentVo1.setSjgl(previousVo1.getSjgl() + currentVo1.getSjgl());
+                                    currentVo1.setYcgl(previousVo1.getYcgl() + currentVo1.getYcgl());
+                                }
+                            }
+                        } else if (wpId.contains("PTZ_FDC_STA")) {
+                            if (map.containsKey("SXJ_KGDL_PTZF01_EG")) {
+                                List<ForecastVo> previousVos1 = (List<ForecastVo>) map.get("SXJ_KGDL_PTZF01_EG");
+                                for (int i = 0; i < vos3.size(); i++) {
+                                    ForecastVo previousVo1 = previousVos1.get(i);
+                                    ForecastVo currentVo1 = vos3.get(i);
+
+                                    currentVo1.setSjgl(previousVo1.getSjgl() + currentVo1.getSjgl());
+                                    currentVo1.setYcgl(previousVo1.getYcgl() + currentVo1.getYcgl());
+                                }
+                            }
+                        }
+
+                        if (wpId.contains("GJY")) {
+                            map.put("SXJ_KGDL_GJY_FDC_STA", vos1);
+
+                        }
+                        if (wpId.contains("NJL")) {
+                            map.put("SXJ_KGDL_NJL_FDC_STA", vos4);
+
+                        }
+                        if (wpId.contains("PTZ_FDC_STA")) {
+                            map.put("SXJ_KGDL_PTZ_FDC_STA", vos3);
+
+                        }
+
+                        if (wpId.contains("TZ_GDC_STA")) {
+                            map.put("SXJ_KGDL_TZ_GDC_STA", vos2);
+                        }
+
+                        if (wpId.contains("SY")) {
+                            map.put("SXJ_KGDL_SY_FDC_STA", vos5);
+                        }
+
+                    }
+                }
+
+            } else {
+                for (ProBasicPowerstation wp : station) {
+                    vos = new ArrayList<>();
+                    Map<String, ProBasicPowerstationPoint> proBasicWppointMap = wppointmap.get(wp.getId());
+                    ProBasicPowerstationPoint ycgl1 = null;
+                    ProBasicPowerstationPoint sjgl1 = null;
+
+                    if (wpId.endsWith("FDC_STA") && type.equals("F")) {
+                        ycgl1 = proBasicWppointMap.get( ContantXk.ZYCGL);
+                        sjgl1 = proBasicWppointMap.get(ContantXk.PJGL15);
+                    }
+                    if (wpId.endsWith("GDC_STA") && type.equals("G")) {
+                        ycgl1 = proBasicWppointMap.get(ContantXk.ZYCGL);
+                        sjgl1 = proBasicWppointMap.get(ContantXk.PJGL15);
+                    }
+                    if (sjgl1 != null) {
+                        List<PointData> ycglls = edosUtil.getHistoryDatasSnap(ycgl1, beginDate.getTime() / 1000, endDate.getTime() / 1000, null, 900L);
+                        List<PointData> sjglls = edosUtil.getHistoryDatasSnap(sjgl1, beginDate.getTime() / 1000, endDate.getTime() / 1000, null, 900L);
+
+                        double temp3 = 0;
+                        double temp4 = 0;
+                        for (int i = 0; i < sjglls.size(); i++) {
+
+                            ForecastVo vo = new ForecastVo();
+                            vo.setSjgl(0.0); //实际功率
+                            vo.setYcgl(0.0); //功率预测
+                            vo.setHours(2023L);  //时间戳
+                            vo.setName(wpId);
+
+                            temp3 = ycglls.get(i).getPointValueInDouble();
+                            vo.setYcgl(StringUtils.round(temp3, 2));
+
+                            temp4 = sjglls.get(i).getPointValueInDouble();
+                            vo.setSjgl(StringUtils.round(temp4 /1000, 2));
+                            vo.setHours(sjglls.get(i).getPointTime());
+
+                            vo.setName(wp.getAname());
+                            vo.setId(wpId);
+
+                            vos.add(vo);
+                        }
+                        map.put(wp.getId(), vos);
+
+                    }
+                }
+            }
+        }
+
+        List<ProEconStationPower> stringList = new ArrayList<>();
+        Date currenttime = new Date();
+        for (Map.Entry<String, Object> entry : map.entrySet()) {
+            String key = entry.getKey();
+
+            List<ProBasicPowerstation> powerstations = CacheContext.wpls;
+            for (ProBasicPowerstation p1 : powerstations){
+                if (key.equals(p1.getId())) {
+                    ArrayList<ForecastVo> forecastVos = (ArrayList<ForecastVo>) entry.getValue();
+
+                    double[] sjglarr=new double[forecastVos.size()];
+                    double[] ycglarr=new double[forecastVos.size()];
+                    double dlycTotal = 0.0; // 累加的总值
+                    for (int i=0;i< forecastVos.size();i++) {
+                        ForecastVo forecastVo=forecastVos.get(i);
+                        sjglarr[i]=forecastVo.getSjgl();
+                        ycglarr[i]=forecastVo.getYcgl();
+                        double dlyc = 24.0 * forecastVo.getYcgl() / forecastVos.size(); // 每次循环的值
+                        dlycTotal += dlyc; // 累加每次循环的值
+                    }
+
+                    double Capacity = p1.getJrwindCapacity();
+
+
+                    double accuracy = shortTermPowerPredictionAccuracyCalculator.calculateAccuracy(ycglarr,sjglarr, Capacity);
+
+                    ProEconStationPower power = new ProEconStationPower();
+                    power.setId(StringUtils.getUUID());
+                    power.setPowerAccuracy(BigDecimal.valueOf(accuracy));
+                    power.setWindpowerstationId(p1.getId());
+                    power.setRecordDate(currenttime);
+                    power.setDayPowerForecast(BigDecimal.valueOf(dlycTotal));
+                    stringList.add(power);
+                    powerService.batchAdd(stringList);
+                }
+            }
+        }
+    }
+}

realtime/generationXK-service/src/main/java/com/gyee/generation/service/auto/IProEconStationPowerService.java

@@ -0,0 +1,18 @@
+package com.gyee.generation.service.auto;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.gyee.generation.model.auto.ProEconStationPower;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 预测功率合格 服务类
+ * </p>
+ *
+ * @author xieshengjie
+ * @since 2023-09-13
+ */
+public interface IProEconStationPowerService extends IService<ProEconStationPower> {
+    boolean batchAdd (List<ProEconStationPower> proEconStationPowers);
+}

realtime/generationXK-service/src/main/java/com/gyee/generation/service/auto/impl/ProEconStationPowerServiceImpl.java

@@ -0,0 +1,43 @@
+package com.gyee.generation.service.auto.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.gyee.generation.mapper.auto.ProEconStationPowerMapper;
+import com.gyee.generation.model.auto.ProEconStationPower;
+import com.gyee.generation.service.auto.IProEconStationPowerService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 预测功率合格 服务实现类
+ * </p>
+ *
+ * @author xieshengjie
+ * @since 2023-09-13
+ */
+@Service
+public class ProEconStationPowerServiceImpl extends ServiceImpl<ProEconStationPowerMapper, ProEconStationPower> implements IProEconStationPowerService {
+
+    @Override
+    public boolean batchAdd(List<ProEconStationPower> proEconStationPowers) {
+        try {
+            proEconStationPowers.stream().forEach(i -> {
+                QueryWrapper<ProEconStationPower> qw = new QueryWrapper<>();
+                qw.lambda().eq(ProEconStationPower::getRecordDate, i.getRecordDate());
+                qw.lambda().eq(ProEconStationPower::getId, i.getId());
+                int count = baseMapper.selectCount(qw);
+                if (count <= 0) {
+                    baseMapper.insert(i);
+                }
+
+            });
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+
+        return true;
+    }
+}

realtime/generationXK-service/src/main/java/com/gyee/generation/task/SaticSchedulePgTask.java

@@ -3,6 +3,7 @@ package com.gyee.generation.task;
 
 import com.gyee.common.util.DateUtils;
 import com.gyee.generation.service.*;
+import com.gyee.generation.service.StationPower.StationPowerService;
 import com.gyee.generation.util.math.AvailablePowerAccuracyCalculator;
 import com.gyee.generation.util.math.PowerPredictionErrorCalculator;
 import com.gyee.generation.util.math.ShortTermPowerPredictionAccuracyCalculator;
@@ -87,7 +88,11 @@ public class SaticSchedulePgTask {
     @Resource
     private InitialRedisService initialRedisService;
 
+    @Resource
+    private ShortTermPowerPredictionAccuracyCalculator shortTermPowerPredictionAccuracyCalculator;
 
+    @Resource
+    private StationPowerService powerService;
     /**
      * 缓存Redis散点图数据
      * 每天执行一次
@@ -1053,7 +1058,7 @@ public class SaticSchedulePgTask {
             double installedCapacity=0 ; /* 装机容量 */;
 
             // 计算准确率
-            double accuracy = ShortTermPowerPredictionAccuracyCalculator.calculateAccuracy(predictedPower, actualPower, installedCapacity);
+            double accuracy = shortTermPowerPredictionAccuracyCalculator.calculateAccuracy(predictedPower, actualPower, installedCapacity);
 
             // 输出结果
             System.out.println("超短期预测曲线准确率: " + accuracy + "%");
@@ -1129,4 +1134,17 @@ public class SaticSchedulePgTask {
         }
         XxlJobHelper.log("可用功率精度计算调度程序处理完成!........");
     }
+
+    @XxlJob("PredictedPowerccuracy")
+    public void Powerccuracy()  {
+
+
+        XxlJobHelper.log("预测功率准确率计算执行开始!........");
+        try {
+                    powerService.predictedPower();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        XxlJobHelper.log("预测功率准确率计算执行开始!........");
+    }
 }

realtime/generationXK-service/src/main/java/com/gyee/generation/util/math/ShortTermPowerPredictionAccuracyCalculator.java

@@ -1,9 +1,12 @@
 package com.gyee.generation.util.math;
 
+import org.springframework.stereotype.Service;
+
+@Service
 public class ShortTermPowerPredictionAccuracyCalculator {
 
 
-    public static double calculateAccuracy(double[] predictedPower, double[] actualPower, double installedCapacity) {
+    public  double calculateAccuracy(double[] predictedPower, double[] actualPower, double installedCapacity) {
         int n = predictedPower.length;
         double totalError = 0.0;
         int validPoints = 0;

realtime/generationXK-service/src/main/java/com/gyee/generation/util/realtimesource/timeseries/ForecastVo.java

@@ -0,0 +1,53 @@
+package com.gyee.generation.util.realtimesource.timeseries;
+
+public class ForecastVo {
+
+    private Long hours;
+
+    private String name;
+    private String id;
+    private Double sjgl;
+
+    private Double ycgl;
+
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public Long getHours() {
+        return hours;
+    }
+
+    public void setHours(Long hours) {
+        this.hours = hours;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public Double getSjgl() {
+        return sjgl;
+    }
+
+    public void setSjgl(Double sjgl) {
+        this.sjgl = sjgl;
+    }
+
+    public Double getYcgl() {
+        return ycgl;
+    }
+
+    public void setYcgl(Double ycgl) {
+        this.ycgl = ycgl;
+    }
+}

realtime/generationXK-service/src/main/resources/xxl-job-accuracy.properties

@@ -0,0 +1,25 @@
+### xxl-job admin address list, such as "http://address" or "http://address01,http://address02"
+xxl.job.admin.addresses=http://10.81.3.152:8179/xxl-job-admin
+
+### xxl-job, access token
+xxl.job.accessToken=
+
+### xxl-job executor appname
+### 场站计算
+#xxl.job.executor.appname=generationWP-job
+### 区域公司计算
+xxl.job.executor.appname=accuracy-job
+### xxl-job executor registry-address: default use address to registry , otherwise use ip:port if address is null
+xxl.job.executor.address=
+### xxl-job executor server-info
+xxl.job.executor.ip=
+#场站端口
+#xxl.job.executor.port=9201
+#区域端口
+xxl.job.executor.port=9377
+
+### xxl-job executor log-path
+xxl.job.executor.logpath=E:\gyee\log\accuracylog
+### xxl-job executor log-retention-days
+xxl.job.executor.logretentiondays=30
+