光资源

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

@@ -0,0 +1,93 @@
+package com.gyee.runeconomy.controller.Windresourceanalysis;
+
+import com.gyee.runeconomy.dto.AjaxResult;
+import com.gyee.runeconomy.dto.DataVo;
+import com.gyee.runeconomy.dto.WindspeedVo;
+import com.gyee.runeconomy.dto.pewpVo;
+import com.gyee.runeconomy.service.Windresourceanalysis.WindresourceanalysisService;
+import com.gyee.runeconomy.util.StringUtils;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.List;
+
+@Controller
+@RequestMapping("//analysisfx")
+@Api(value = "光伏系统效率计算", tags = "光伏系统效率计算")
+public class WindresourceanalysisController {
+    @Resource
+    private WindresourceanalysisService windresourceanalysisService;
+    @GetMapping("/fdanalysis")
+    @ResponseBody
+    @ApiOperation(value = "pr分析", notes = "pr分析")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "Data", value = "日期", required = true, dataType = "string", paramType = "query")
+    })
+
+    public AjaxResult prfx(String Data) throws Exception {
+
+        List<WindspeedVo> resultList = new ArrayList<>();
+        if (StringUtils.notEmp(Data)) {
+            resultList = windresourceanalysisService.Comprehensive(Data);
+        }
+
+        if (null != resultList) {
+            return AjaxResult.successData(200, resultList);
+        } else {
+            return AjaxResult.error(500, "操作失败");
+        }
+
+    }
+
+    @GetMapping("/gzanalysis")
+    @ResponseBody
+    @ApiOperation(value = "pr分析", notes = "pr分析")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "Data", value = "日期", required = true, dataType = "string", paramType = "query")
+    })
+
+    public AjaxResult pgzfx(String Data) throws Exception {
+
+        List<pewpVo> resultList = new ArrayList<>();
+        if (StringUtils.notEmp(Data)) {
+            resultList = windresourceanalysisService.gzComprehensive(Data);
+        }
+
+        if (null != resultList) {
+            return AjaxResult.successData(200, resultList);
+        } else {
+            return AjaxResult.error(500, "操作失败");
+        }
+
+    }
+
+    @GetMapping("/GFGroupRealtime")
+    @ResponseBody
+    @ApiOperation(value = "首页实时数据", notes = "首页实时数据")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "Data", value = "日期", required = true, dataType = "string", paramType = "query")
+    })
+    public AjaxResult GroupRealtime(String Data) throws Exception {
+
+        List<DataVo> resultList = new ArrayList<>();
+        if (StringUtils.notEmp(Data)) {
+            resultList = windresourceanalysisService.GroupRealtimevalue(Data);
+        }
+
+        if (null != resultList) {
+            return AjaxResult.successData(200, resultList);
+        } else {
+            return AjaxResult.error(500, "操作失败");
+        }
+
+    }
+
+}

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/dto/WindspeedVo.java

@@ -0,0 +1,86 @@
+package com.gyee.runeconomy.dto;
+
+public class WindspeedVo {
+
+    /**
+     * 场站名称
+     */
+
+    private String wpid;
+
+    /**
+     * 场站名称
+     */
+
+    private String name;
+
+    /**
+     * 平均风速
+     */
+
+    private Double pjfs;
+
+    /**
+     * 最大风速
+     */
+
+    private Double zdfs;
+
+    /**
+     * 最小风速
+     */
+    private Double zxfs;
+
+    /**
+     * 平均风向
+     */
+    private Double pjfx;
+
+    public String getWpid() {
+        return wpid;
+    }
+
+    public void setWpid(String wpid) {
+        this.wpid = wpid;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public Double getPjfs() {
+        return pjfs;
+    }
+
+    public void setPjfs(Double pjfs) {
+        this.pjfs = pjfs;
+    }
+
+    public Double getZdfs() {
+        return zdfs;
+    }
+
+    public void setZdfs(Double zdfs) {
+        this.zdfs = zdfs;
+    }
+
+    public Double getZxfs() {
+        return zxfs;
+    }
+
+    public void setZxfs(Double zxfs) {
+        this.zxfs = zxfs;
+    }
+
+    public Double getPjfx() {
+        return pjfx;
+    }
+
+    public void setPjfx(Double pjfx) {
+        this.pjfx = pjfx;
+    }
+}

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/dto/pewpVo.java

@@ -0,0 +1,98 @@
+package com.gyee.runeconomy.dto;
+
+import java.util.Date;
+
+public class pewpVo {
+
+    /**
+     * 场站名称
+     */
+
+    private String wpid;
+
+    /**
+     * 场站名称
+     */
+
+    private String name;
+    /**
+     * 总辐照度
+     */
+    private Double zfzd;
+
+    /**
+     * 日最大辐照度
+     */
+    private Double zdfdz;
+
+    /**
+     * 日出时间
+     */
+    private Date rcsj;
+
+    /**
+     * 日落时间
+     */
+    private Date rlsj;
+
+    /**
+     * 持续时间
+     */
+    private Double cxsj;
+
+    public String getWpid() {
+        return wpid;
+    }
+
+    public void setWpid(String wpid) {
+        this.wpid = wpid;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public Double getZfzd() {
+        return zfzd;
+    }
+
+    public void setZfzd(Double zfzd) {
+        this.zfzd = zfzd;
+    }
+
+    public Double getZdfdz() {
+        return zdfdz;
+    }
+
+    public void setZdfdz(Double zdfdz) {
+        this.zdfdz = zdfdz;
+    }
+
+    public Date getRcsj() {
+        return rcsj;
+    }
+
+    public void setRcsj(Date rcsj) {
+        this.rcsj = rcsj;
+    }
+
+    public Date getRlsj() {
+        return rlsj;
+    }
+
+    public void setRlsj(Date rlsj) {
+        this.rlsj = rlsj;
+    }
+
+    public Double getCxsj() {
+        return cxsj;
+    }
+
+    public void setCxsj(Double cxsj) {
+        this.cxsj = cxsj;
+    }
+}

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/service/Windresourceanalysis/WindresourceanalysisService.java

@@ -0,0 +1,267 @@
+package com.gyee.runeconomy.service.Windresourceanalysis;
+
+import com.gyee.common.contant.ContantXk;
+import com.gyee.common.model.PointData;
+import com.gyee.common.model.StringUtils;
+import com.gyee.common.util.DateUtils;
+import com.gyee.runeconomy.dto.DataVo;
+import com.gyee.runeconomy.dto.WindspeedVo;
+import com.gyee.runeconomy.dto.pewpVo;
+import com.gyee.runeconomy.init.CacheContext;
+import com.gyee.runeconomy.model.auto.ProBasicPowerstation;
+import com.gyee.runeconomy.model.auto.ProBasicPowerstationPoint;
+import com.gyee.runeconomy.service.auto.IProBasicPowerstationPointService;
+import com.gyee.runeconomy.service.auto.IProEconPowerstationInfoDay1Service;
+import com.gyee.runeconomy.util.realtimesource.IEdosUtil;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.text.SimpleDateFormat;
+import java.util.*;
+import java.util.stream.Collectors;
+
+@Service
+public class WindresourceanalysisService {
+
+    @Resource
+    private IProEconPowerstationInfoDay1Service proEconPowerstationInfoDay1Service;
+
+    @Resource
+    private IProBasicPowerstationPointService proBasicPowerstationPointService;
+
+    @Resource
+    private IEdosUtil edosUtil;
+
+    public List<WindspeedVo> Comprehensive(String Data) throws Exception {
+
+        List<ProBasicPowerstation> wplsf = CacheContext.wplsf;
+
+        //转换时间为Date类型
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+        Date date = sdf.parse(Data);
+
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(date);
+        calendar.add(Calendar.DAY_OF_MONTH, -1);
+        calendar.set(Calendar.HOUR_OF_DAY, 23);
+        calendar.set(Calendar.MINUTE, 59);
+        calendar.set(Calendar.SECOND, 59);
+
+        Date startTime = calendar.getTime();
+
+        Calendar calendar1 = Calendar.getInstance();
+        calendar1.setTime(date);
+        calendar1.set(Calendar.HOUR_OF_DAY, 23);
+        calendar1.set(Calendar.MINUTE, 59);
+        calendar1.set(Calendar.SECOND, 59);
+
+        Date endTime = calendar1.getTime();
+
+        ProBasicPowerstationPoint pjfs = null;
+        List<WindspeedVo> vos = new ArrayList<>();
+        for (ProBasicPowerstation wp : wplsf) {
+
+            pjfs = proBasicPowerstationPointService.getPowerstationPoint(wp.getId(), ContantXk.GCGZQD);
+
+            if (pjfs != null && pjfs != null) {
+                List<PointData> pjfsls = edosUtil.getHistoryDatasRaw(pjfs.getNemCode(), startTime.getTime() / 1000, endTime.getTime() / 1000);
+
+                if (pjfsls != null && !pjfsls.isEmpty()) {
+
+                    List<PointData> filterls = new ArrayList<>();
+                    for (PointData po : pjfsls) {
+                        if (po.getPointValueInDouble() > 10) {
+                            filterls.add(po);
+                        }
+                    }
+
+
+                    if (!filterls.isEmpty()) {
+
+                        Date beginTime1 = new Date(filterls.get(0).getPointTime());
+                        Date endTime1 = new Date(filterls.get(filterls.size() - 1).getPointTime());
+
+                        double hours = DateUtils.hoursDiff(beginTime1, endTime1);
+
+                        DoubleSummaryStatistics summaryStatistics = filterls.stream().mapToDouble(PointData::getPointValueInDouble).summaryStatistics();
+
+                        double sum = filterls.stream()
+                                .mapToDouble(PointData::getPointValueInDouble)
+                                .sum();
+
+                         WindspeedVo vo = new WindspeedVo();
+                        vo.setWpid(wp.getId());
+                        vo.setName(wp.getName());
+
+                        //日最大风速
+                        vo.setZdfs(StringUtils.round(summaryStatistics.getMax() /1000, 2));
+//                        vo.getPjfs(StringUtils.round(summaryStatistics.getAverage()));
+
+                        vos.add(vo);
+                        //日最小风速
+//                    pewp.setRzxfs(StringUtils.round(summaryStatistics.getMin(), 2));
+
+                        double avg = StringUtils.round(summaryStatistics.getAverage(), 2);
+
+                        double result = new BigDecimal(avg * hours).divide(new BigDecimal(1000), 2, RoundingMode.HALF_EVEN).doubleValue();
+//                        vo.setZfzd(StringUtils.round(result,2));
+
+                        //日平均风速
+//                    pewp.setRpjfs(result);
+
+
+                    }
+
+                }
+            }
+        }
+
+        return vos;
+
+    }
+
+
+    public List<pewpVo> gzComprehensive(String Data) throws Exception {
+
+        List<ProBasicPowerstation> wplsg = CacheContext.wplsG;
+
+        //转换时间为Date类型
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+        Date date = sdf.parse(Data);
+
+//        Calendar calendar = Calendar.getInstance();
+//        calendar.setTime(date);
+//        calendar.set(Calendar.HOUR_OF_DAY, 0);
+//        calendar.set(Calendar.MINUTE, 0);
+//        calendar.set(Calendar.SECOND, 0);
+//        Date startTime = calendar.getTime();
+
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(date);
+        calendar.add(Calendar.DAY_OF_MONTH, -1);
+        calendar.set(Calendar.HOUR_OF_DAY, 23);
+        calendar.set(Calendar.MINUTE, 59);
+        calendar.set(Calendar.SECOND, 59);
+
+        Date startTime = calendar.getTime();
+
+//        calendar.set(Calendar.HOUR_OF_DAY, 23);
+//        calendar.set(Calendar.MINUTE, 59);
+//        calendar.set(Calendar.SECOND, 59);
+//
+//        Date endTime = calendar.getTime();
+        Calendar calendar1 = Calendar.getInstance();
+        calendar1.setTime(date);
+        calendar1.set(Calendar.HOUR_OF_DAY, 23);
+        calendar1.set(Calendar.MINUTE, 59);
+        calendar1.set(Calendar.SECOND, 59);
+
+        Date endTime = calendar1.getTime();
+
+        ProBasicPowerstationPoint pjfs = null;
+        List<pewpVo> vos = new ArrayList<>();
+        for (ProBasicPowerstation wp : wplsg) {
+
+            pjfs = proBasicPowerstationPointService.getPowerstationPoint(wp.getId(), ContantXk.GCGZQD);
+
+            if (pjfs != null && pjfs != null) {
+                List<PointData> pjfsls = edosUtil.getHistoryDatasRaw(pjfs.getNemCode(), startTime.getTime() / 1000, endTime.getTime() / 1000);
+
+                if (pjfsls != null && !pjfsls.isEmpty()) {
+
+                    List<PointData> filterls = new ArrayList<>();
+                    for (PointData po : pjfsls) {
+                        if (po.getPointValueInDouble() > 10) {
+                            filterls.add(po);
+                        }
+                    }
+
+
+                if (!filterls.isEmpty()) {
+
+                    Date beginTime1 = new Date(filterls.get(0).getPointTime());
+                    Date endTime1 = new Date(filterls.get(filterls.size() - 1).getPointTime());
+
+                    double hours = DateUtils.hoursDiff(beginTime1, endTime1);
+
+                    DoubleSummaryStatistics summaryStatistics = filterls.stream().mapToDouble(PointData::getPointValueInDouble).summaryStatistics();
+
+                    double sum = filterls.stream()
+                            .mapToDouble(PointData::getPointValueInDouble)
+                            .sum();
+                    pewpVo vo = new pewpVo();
+                    vo.setWpid(wp.getId());
+                    vo.setName(wp.getName());
+
+                    //日最大辐照度
+                    vo.setZdfdz(StringUtils.round(summaryStatistics.getMax() /1000, 2));
+                    vo.setRcsj(beginTime1);
+                    vo.setRlsj(endTime1);
+                    vo.setCxsj(hours);
+                    vos.add(vo);
+                    //日最小风速
+//                    pewp.setRzxfs(StringUtils.round(summaryStatistics.getMin(), 2));
+
+                    double avg = StringUtils.round(summaryStatistics.getAverage(), 2);
+
+                    double result = new BigDecimal(avg * hours).divide(new BigDecimal(1000), 2, RoundingMode.HALF_EVEN).doubleValue();
+                    vo.setZfzd(StringUtils.round(result,2));
+
+                    //日平均风速
+//                    pewp.setRpjfs(result);
+
+
+                }
+
+            }
+            }
+        }
+
+        return vos;
+    }
+
+
+    public List<DataVo> GroupRealtimevalue(String Data) throws Exception {
+
+        List<DataVo> vos = new ArrayList<DataVo>();
+
+        //转换时间为Date类型
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+        Date date = sdf.parse(Data);
+
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(date);
+        calendar.add(Calendar.DAY_OF_MONTH, -1);
+        calendar.set(Calendar.HOUR_OF_DAY, 23);
+        calendar.set(Calendar.MINUTE, 59);
+        calendar.set(Calendar.SECOND, 59);
+
+        Date startTime = calendar.getTime();
+
+        Calendar calendar1 = Calendar.getInstance();
+        calendar1.setTime(date);
+        calendar1.set(Calendar.HOUR_OF_DAY, 23);
+        calendar1.set(Calendar.MINUTE, 59);
+        calendar1.set(Calendar.SECOND, 59);
+
+        Date endTime = calendar1.getTime();
+        ProBasicPowerstationPoint gzzs = null;
+        List<ProBasicPowerstation> wplsG = CacheContext.wplsG.stream().filter(c->c.getOrderNum().equals(15)).collect(Collectors.toList());
+        gzzs = proBasicPowerstationPointService.getPowerstationPoint(wplsG.get(0).getId(), ContantXk.GCGZQD);
+
+
+            List<PointData> gzzsls = edosUtil.getHistoryDatasRaw(gzzs.getNemCode(), startTime.getTime() / 1000, endTime.getTime() / 1000);
+            double temp6 = 0;
+            for (int i = 0; i < gzzsls.size(); i++) {
+                DataVo vo = new DataVo();
+                temp6 = gzzsls.get(i).getPointValueInDouble();
+                vo.setValue6(com.gyee.runeconomy.util.StringUtils.round(temp6, 2));
+                vo.setTime(gzzsls.get(i).getPointTime());
+                vos.add(vo);
+            }
+
+        return vos;
+    }
+}

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/service/monitor/GroupRealtimeService.java

@@ -4,6 +4,8 @@ import com.gyee.common.contant.ContantXk;
 import com.gyee.common.model.PointData;
 import com.gyee.common.util.DateUtils;
 import com.gyee.runeconomy.dto.DataVo;
+import com.gyee.runeconomy.init.CacheContext;
+import com.gyee.runeconomy.model.auto.ProBasicPowerstation;
 import com.gyee.runeconomy.model.auto.ProBasicPowerstationPoint;
 import com.gyee.runeconomy.service.TokenService;
 import com.gyee.runeconomy.service.auto.*;
@@ -15,6 +17,7 @@ import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
 import java.util.*;
+import java.util.stream.Collectors;
 
 @Service
 public class GroupRealtimeService {
@@ -142,7 +145,13 @@ public class GroupRealtimeService {
         ProBasicPowerstationPoint ssfs = proBasicPowerstationPointService.getPowerstationPoint(wpId, ContantXk.SSPJFS);
         ProBasicPowerstationPoint llgl = proBasicPowerstationPointService.getPowerstationPoint(wpId, ContantXk.TPOINT_WP_YCGL); //预测功率
 //        ProBasicPowerstationPoint sjgl = proBasicPowerstationPointService.getPowerstationPoint(wpId, ContantXk.SSZGL);
-        ProBasicPowerstationPoint gzzs = proBasicPowerstationPointService.getPowerstationPoint(wpId, ContantXk.RPJGZD);
+        ProBasicPowerstationPoint gzzs = null;
+        if (wpId.contains(QS) || wpId.contains(FD) ||wpId.contains(GF)) {
+            List<ProBasicPowerstation> wplsG = CacheContext.wplsG.stream().filter(c->c.getOrderNum().equals(15)).collect(Collectors.toList());
+            gzzs = proBasicPowerstationPointService.getPowerstationPoint(wplsG.get(0).getId(), ContantXk.GCGZQD);
+        }else {
+           gzzs = proBasicPowerstationPointService.getPowerstationPoint(wpId, ContantXk.GCGZQD);
+        }
         ProBasicPowerstationPoint fnlyl = proBasicPowerstationPointService.getPowerstationPoint(wpId, ContantXk.FNLYL);
 
         if (uniformCode.contains("SSPJFS")) {