添加值际对标代码

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/controller/ProEconBenchmarkingBetweenController.java

@@ -0,0 +1,51 @@
+package com.gyee.runeconomy.controller;
+
+
+import com.gyee.common.util.DateUtils;
+import com.gyee.runeconomy.dto.R;
+import com.gyee.runeconomy.dto.ResultMsg;
+import com.gyee.runeconomy.model.auto.ProEconBenchmarkingBetween;
+import com.gyee.runeconomy.service.auto.IProEconBenchmarkingBetweenService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author wang
+ * @since 2023-02-03
+ */
+@RestController
+@RequestMapping("//pro-econ-benchmarking-between")
+public class ProEconBenchmarkingBetweenController {
+
+    @Autowired
+    private IProEconBenchmarkingBetweenService proEconBenchmarkingBetweenService;
+
+    /**
+     * 值际损失电量
+     * @param beginDate
+     * @param endDate
+     * @return
+     */
+    @GetMapping("/zjwxssl")
+    @ResponseBody
+    @CrossOrigin(origins = "*", maxAge = 3600)
+    public R zjwxssl(@RequestParam(value = "beginDate",required = true)String beginDate,
+                     @RequestParam(value = "endDate",required = true)String endDate){
+        Date begin = DateUtils.parseDate(beginDate);
+        Date end = DateUtils.parseDate(endDate);
+        List<ProEconBenchmarkingBetween> resultList =  proEconBenchmarkingBetweenService.findByBeginAndEnd(begin,end);
+        if (null != resultList) {
+            return R.data(ResultMsg.ok(resultList));
+        } else {
+            return R.error(ResultMsg.error());
+        }
+    }
+
+}

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/controller/ProEconDutyScheduleController.java

@@ -0,0 +1,20 @@
+package com.gyee.runeconomy.controller;
+
+
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author wang
+ * @since 2023-02-03
+ */
+@RestController
+@RequestMapping("//pro-econ-duty-schedule")
+public class ProEconDutyScheduleController {
+
+}

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

@@ -0,0 +1,24 @@
+package com.gyee.runeconomy.mapper.auto;
+
+import com.gyee.runeconomy.model.auto.ProEconBenchmarkingBetween;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author wang
+ * @since 2023-02-03
+ */
+public interface ProEconBenchmarkingBetweenMapper extends BaseMapper<ProEconBenchmarkingBetween> {
+
+    @Select("select duty_name,sum(theoretical_generatity) theoreticalgeneratity,sum(generatity) generatity,sum(fault_loss) faultloss,sum(main_loss) mainloss,sum(performance_loss) performanceloss,sum(rationing_loss) rationingloss,sum(involves_loss) involvesloss from pro_econ_benchmarking_between where theday>=#{begin} and theday <=#{end} group by duty_name ")
+    public List<ProEconBenchmarkingBetween> findByBeginAndEnd(@Param(value = "begin") Date begin, @Param(value = "end")Date end);
+
+}

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

@@ -0,0 +1,16 @@
+package com.gyee.runeconomy.mapper.auto;
+
+import com.gyee.runeconomy.model.auto.ProEconDutySchedule;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author wang
+ * @since 2023-02-03
+ */
+public interface ProEconDutyScheduleMapper extends BaseMapper<ProEconDutySchedule> {
+
+}

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

@@ -0,0 +1,104 @@
+package com.gyee.runeconomy.model.auto;
+
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import java.util.Date;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author wang
+ * @since 2023-02-03
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class ProEconBenchmarkingBetween extends Model {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 编号
+     */
+    private String id;
+
+    /**
+     * 值班名称
+     */
+    private String dutyName;
+
+    /**
+     * 日期
+     */
+    private Date theday;
+
+    /**
+     * 理论发电量
+     */
+    private Double theoreticalGeneratity;
+
+    /**
+     * 发电量
+     */
+    private Double generatity;
+
+    /**
+     * 故障损失
+     */
+    private Double faultLoss;
+
+    /**
+     * 故障率
+     */
+    private Double faultRate;
+
+    /**
+     * 维护损失
+     */
+    private Double mainLoss;
+
+    /**
+     * 维护率
+     */
+    private Double mainRate;
+
+    /**
+     * 性能损失
+     */
+    private Double performanceLoss;
+
+    /**
+     * 性能率
+     */
+    private Double performanceRate;
+
+    /**
+     * 限电损失
+     */
+    private Double rationingLoss;
+
+    /**
+     * 限电率
+     */
+    private Double rationingRate;
+
+    /**
+     * 受累损失
+     */
+    private Double involvesLoss;
+
+    /**
+     * 受累率
+     */
+    private Double involvesRate;
+
+    /**
+     * 风能利用率
+     */
+    private Double fnlyl;
+
+
+}

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

@@ -0,0 +1,49 @@
+package com.gyee.runeconomy.model.auto;
+
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import java.time.LocalDate;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author wang
+ * @since 2023-02-03
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class ProEconDutySchedule extends Model {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 编号
+     */
+    private String id;
+
+    /**
+     * 名称
+     */
+    private String name;
+
+    /**
+     * 开始时间
+     */
+    private String begin;
+
+    /**
+     * 结束时间
+     */
+    private String end;
+
+    /**
+     * 创建日期
+     */
+    private LocalDate createdate;
+
+
+}

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

@@ -0,0 +1,24 @@
+package com.gyee.runeconomy.service.auto;
+
+import com.gyee.runeconomy.model.auto.ProEconBenchmarkingBetween;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+import java.text.ParseException;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author wang
+ * @since 2023-02-03
+ */
+public interface IProEconBenchmarkingBetweenService extends IService<ProEconBenchmarkingBetween> {
+
+    void saveBeanchmarkList(String beginDate,String endDate) throws ParseException, Exception;
+
+    List<ProEconBenchmarkingBetween> findByBeginAndEnd(Date begin, Date end);
+
+}

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

@@ -0,0 +1,16 @@
+package com.gyee.runeconomy.service.auto;
+
+import com.gyee.runeconomy.model.auto.ProEconDutySchedule;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author wang
+ * @since 2023-02-03
+ */
+public interface IProEconDutyScheduleService extends IService<ProEconDutySchedule> {
+
+}

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

@@ -0,0 +1,156 @@
+package com.gyee.runeconomy.service.auto.impl;
+
+import com.gyee.common.contant.Contant;
+import com.gyee.common.model.PointData;
+import com.gyee.common.model.StringUtils;
+import com.gyee.common.util.DateUtils;
+import com.gyee.runeconomy.init.CacheContext;
+import com.gyee.runeconomy.model.auto.ProBasicPowerstationPoint;
+import com.gyee.runeconomy.model.auto.ProEconBenchmarkingBetween;
+import com.gyee.runeconomy.mapper.auto.ProEconBenchmarkingBetweenMapper;
+import com.gyee.runeconomy.model.auto.ProEconDutySchedule;
+import com.gyee.runeconomy.service.auto.IProEconBenchmarkingBetweenService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.gyee.runeconomy.service.auto.IProEconDutyScheduleService;
+import com.gyee.runeconomy.util.realtimesource.EdosUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+/**
+ * <p>
+ * 服务实现类
+ * </p>
+ *
+ * @author wang
+ * @since 2023-02-03
+ */
+@Service
+public class ProEconBenchmarkingBetweenServiceImpl extends ServiceImpl<ProEconBenchmarkingBetweenMapper, ProEconBenchmarkingBetween> implements IProEconBenchmarkingBetweenService {
+
+
+    @Autowired
+    private IProEconDutyScheduleService proEconDutyScheduleService;
+
+    @Resource
+    private ProEconBenchmarkingBetweenMapper proEconBenchmarkingBetweenMapper;
+
+    private EdosUtil edosUtil = new EdosUtil();
+
+
+
+    /**
+     * 值际五项损失
+     * @param beginDate
+     * @param endDate
+     * @return
+     */
+    public List<ProEconBenchmarkingBetween> findbenchlist(String beginDate, String endDate) {
+        Date begin = DateUtils.parseDate(beginDate);
+        Date end = DateUtils.parseDate(endDate);
+        List<ProEconBenchmarkingBetween> resuList =  proEconBenchmarkingBetweenMapper.findByBeginAndEnd(begin,end);
+        return resuList;
+    }
+
+
+
+
+    @Override
+    public void saveBeanchmarkList(String beginDate, String endDate) throws Exception {
+        List<String> days = getDays(beginDate, endDate);
+
+        for (String day : days) {
+            Date date = DateUtils.parseDate(day);
+            Map<String, Object> params = new HashMap<>();
+            params.put("theday", date);
+            this.removeByMap(params);
+            Map<String, Object> params1 = new HashMap<>();
+            params1.put("create_date", date);
+            List<ProEconDutySchedule> dutyList = proEconDutyScheduleService.listByMap(params1);
+
+            String[] points = Contant.benchPoints.split(",");
+            Map<String, ProBasicPowerstationPoint> wpmap = CacheContext.wppointmap.get("0");
+            SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+            Map<String, Map<String, Double>> remap = new HashMap<>();
+            for (ProEconDutySchedule dutyschedule : dutyList) {
+                String[] begins = dutyschedule.getBegin().split(",");
+                String[] ends = dutyschedule.getEnd().split(",");
+                Map<String, Double> map = new HashMap<>();
+                for (int i = 0; i < begins.length; i++) {
+                    Date begin = df.parse(day + " " + begins[i] + ":00");
+                    Date end = df.parse(day + " " + ends[i] + ":00");
+                    for (String point : points) {
+                        ProBasicPowerstationPoint proBasicPowerstationPoint = wpmap.get(point);
+                        List<PointData> maxs = edosUtil.getHistStat(proBasicPowerstationPoint.getNemCode(), begin.getTime() / 1000, end.getTime() / 1000, (long) 1, null, 0);
+                        List<PointData> mins = edosUtil.getHistStat(proBasicPowerstationPoint.getNemCode(), begin.getTime() / 1000, end.getTime() / 1000, (long) 1, null, 1);
+                        double ssdl = 0;
+                        if (StringUtils.isNotEmpty(maxs) && StringUtils.isNotEmpty(mins)) {
+                            ssdl = (maxs.get(0).getPointValueInDouble() - mins.get(0).getPointValueInDouble()) / 10000;
+                        }
+                        if (!map.containsKey(point)) {
+                            map.put(point, ssdl);
+                        } else {
+                            map.put(point, map.get(point) + ssdl);
+                        }
+                    }
+                    ProBasicPowerstationPoint proBasicPowerstationPoint = wpmap.get("RFDL");
+                    List<PointData> maxs = edosUtil.getHistStat(proBasicPowerstationPoint.getNemCode(), begin.getTime() / 1000, end.getTime() / 1000, (long) 1, null, 0);
+                    List<PointData> mins = edosUtil.getHistStat(proBasicPowerstationPoint.getNemCode(), begin.getTime() / 1000, end.getTime() / 1000, (long) 1, null, 1);
+                    double fdl = 0;
+                    if (StringUtils.isNotEmpty(maxs) && StringUtils.isNotEmpty(mins)) {
+                        fdl = maxs.get(0).getPointValueInDouble() - mins.get(0).getPointValueInDouble();
+                    }
+                    if (!map.containsKey("RFDL")) {
+                        map.put("RFDL", fdl);
+                    } else {
+                        map.put("RFDL", map.get("RFDL") + fdl);
+                    }
+                    remap.put(dutyschedule.getName(), map);
+                }
+            }
+
+            Set<String> dutyset = remap.keySet();
+            for (String duty : dutyset) {
+                ProEconBenchmarkingBetween bench = new ProEconBenchmarkingBetween();
+                bench.setDutyName(duty);
+                bench.setTheday(date);
+                Map<String, Double> pointmap = remap.get(duty);
+                bench.setPerformanceLoss(pointmap.get("RSDJZSDL") + pointmap.get("RSSTZSDL") + pointmap.get("RXNZSDL") + pointmap.get("RSQXZSDL"));
+                bench.setFaultLoss(pointmap.get("RGZZSDL") + pointmap.get("RSZZSDL"));
+                bench.setMainLoss(pointmap.get("RJXZSDL") + pointmap.get("RLZZSDL"));
+                bench.setRationingLoss(pointmap.get("RQFZSDL") + pointmap.get("RXDZSDL"));
+                bench.setInvolvesLoss(pointmap.get("RWZZSDL") + pointmap.get("RTZZSDL"));
+                bench.setGeneratity(pointmap.get("RFDL"));
+                bench.setTheoreticalGeneratity(bench.getPerformanceLoss() + bench.getFaultLoss() + bench.getMainLoss() + bench.getRationingLoss() + bench.getInvolvesLoss() + bench.getGeneratity());
+                this.save(bench);
+            }
+        }
+    }
+
+    @Override
+    public List<ProEconBenchmarkingBetween> findByBeginAndEnd(Date begin, Date end) {
+
+        return  proEconBenchmarkingBetweenMapper.findByBeginAndEnd(begin,end);
+    }
+
+    /**
+     * 获取两日期间日期list
+     *
+     * @param beginDate
+     * @param endDate
+     * @return
+     */
+    public static List<String> getDays(String beginDate, String endDate) {
+        List<String> days = null;
+        if (StringUtils.isNotEmpty(beginDate) && StringUtils.isNotEmpty(endDate)) {
+            days = DateUtils.getDays(beginDate, endDate);
+        } else {
+            days = new ArrayList<>();
+            days.add(DateUtils.getYesterdayStr("yyyy-MM-dd"));
+        }
+        return days;
+    }
+}

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

@@ -0,0 +1,20 @@
+package com.gyee.runeconomy.service.auto.impl;
+
+import com.gyee.runeconomy.model.auto.ProEconDutySchedule;
+import com.gyee.runeconomy.mapper.auto.ProEconDutyScheduleMapper;
+import com.gyee.runeconomy.service.auto.IProEconDutyScheduleService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author wang
+ * @since 2023-02-03
+ */
+@Service
+public class ProEconDutyScheduleServiceImpl extends ServiceImpl<ProEconDutyScheduleMapper, ProEconDutySchedule> implements IProEconDutyScheduleService {
+
+}