gsdb\zqdb

web/runeconomy-jjyx/src/main/java/com/gyee/runeconomy/controller/bmk/BenchmarkingController.java

@@ -68,7 +68,7 @@ public class BenchmarkingController {
 
     @GetMapping(value = "/alllist")
     @ApiOperation(value = "场站之后列表", notes = "场站之后列表")
-    public R alllist(@RequestParam(value = "ids", required = true) String ids,
+    public R alllist(@RequestParam(value = " ", required = true) String ids,
                         @RequestParam(value = "type", required = false) String type) {
 
         List<ProBasicOrganizeTree> resultList = benchmarkingService.allList(ids,type);

web/runeconomy-jjyx/src/main/java/com/gyee/runeconomy/init/CacheContext.java

@@ -16,6 +16,7 @@ import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 import java.util.*;
+import java.util.function.Function;
 import java.util.stream.Collectors;
 
 /**
@@ -168,12 +169,15 @@ public class CacheContext implements CommandLineRunner {
     public static Map<String, Map<Double,ProEconWtPowerCurveFitting>> curveFittingPowerMap = new HashMap<>(); //自算，最优功率
     public static Map<String,List<ProBasicStatusPoint>> statusMap = new HashMap<>();
     public static List<ProBasicOrganizeTree> proBasicOrganizeTrees;
+    public static Map<String, ProBasicOrganizeTree> proBasicOrganizeTreesMap;
 
     @Override
     public void run(String... args) throws Exception {
         logger.info("缓存开始------------------------------------------------------------");
         proBasicOrganizeTrees = proBasicOrganizeTreeService.list();
         proBasicOrganizeTrees = proBasicOrganizeTrees.stream().filter(pbot -> pbot.getIsAble() == 1).collect(Collectors.toList());
+        proBasicOrganizeTreesMap = proBasicOrganizeTrees.stream().collect(Collectors.toMap(ProBasicOrganizeTree::getId, Function.identity()));
+
         List<String> pbotids = proBasicOrganizeTrees.stream().map(pbot -> pbot.getId()).collect(Collectors.toList());
         Map<String, Object> pbotidMap = redisService.batchGetKeys(pbotids);
 

web/runeconomy-jjyx/src/main/java/com/gyee/runeconomy/model/auto/ProEconEquipmentInfoDay1.java

@@ -4,10 +4,11 @@ package com.gyee.runeconomy.model.auto;
 import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.extension.activerecord.Model;
-import java.util.Date;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 
+import java.util.Date;
+
 /**
  * <p>
  * 五损电量
@@ -63,6 +64,8 @@ public class ProEconEquipmentInfoDay1 extends Model {
      */
     private String regionId;
 
+    private String squareId;
+
     /**
      * 日最大风速
      */

web/runeconomy-jjyx/src/main/java/com/gyee/runeconomy/service/bmk/BenchmarkingService.java

@@ -33,6 +33,8 @@ public class BenchmarkingService {
     private final String TYPE_WIND = "wind";
     private final String TYPE_PROJECT = "project";
     private final String TYPE_LINE = "line";
+    private final String TYPE_SQUARE = "square";
+    private final String TYPE_COMPANY = "company";
     private final String TYPE_WINDTURBINE = "windturbine";
 
 
@@ -736,6 +738,14 @@ public class BenchmarkingService {
                 vo.setId(i.getWindturbineId());
                 vo.setName(CacheContext.wtmap.get(i.getWindturbineId().trim()).getAname());
                 vo.setOrdernum(CacheContext.wtmap.get(i.getWindturbineId().trim()).getOrderNum().doubleValue());
+            } else if (type.equals(TYPE_SQUARE)) {
+                vo.setId(i.getSquareId());
+                vo.setName(CacheContext.proBasicOrganizeTreesMap.get(i.getWindturbineId()).getAname());
+                vo.setOrdernum(CacheContext.proBasicOrganizeTreesMap.get(i.getWindturbineId()).getOrderNum().doubleValue());
+            } else if (type.equals(TYPE_COMPANY)) {
+                vo.setId(i.getId());
+                vo.setName(CacheContext.proBasicOrganizeTreesMap.get(i.getId()).getAname());
+                vo.setOrdernum(CacheContext.proBasicOrganizeTreesMap.get(i.getId()).getOrderNum().doubleValue());
             }
             vo.setDate(i.getRecordDate());
             vo.setFdl(DoubleUtils.keepPrecision(i.getRfdl() / 10000, 2));
@@ -903,20 +913,25 @@ public class BenchmarkingService {
     public List<WxsslVo> gsdb(String companys, String type, String beginDate, String endDate, String target, String sort) {
         QueryWrapper<ProEconEquipmentInfoDay1> qw = new QueryWrapper<>();
         List<WxsslVo> resultList = new ArrayList<>();
-        qw.select("record_date,sum(rfdl) rfdl,sum(rllfdl) rllfdl,avg(rpjfs) rpjfs,sum(rjxssdl) rjxssdl,sum(rcnsljxssdl) rcnsljxssdl,sum(rgzssdl) rgzssdl,sum(rcnslgzssdl) rcnslgzssdl,sum(rxdtjssdl) rxdtjssdl,sum(rxdjclssdl) rxdjclssdl,sum(rdjssdl) rdjssdl,sum(rqxjclssdl) rqxjclssdl,sum(rsdtjssdl) rsdtjssdl,sum(rxnssdl) rxnssdl,sum(rcwsldwssdl) rcwsldwssdl,sum(rcwsltqssdl) rcwsltqssdl");
+        String sql=",sum(rfdl) rfdl,sum(rllfdl) rllfdl,avg(rpjfs) rpjfs,sum(rjxssdl) rjxssdl,sum(rcnsljxssdl) rcnsljxssdl,sum(rgzssdl) rgzssdl,sum(rcnslgzssdl) rcnslgzssdl,sum(rxdtjssdl) rxdtjssdl,sum(rxdjclssdl) rxdjclssdl,sum(rdjssdl) rdjssdl,sum(rqxjclssdl) rqxjclssdl,sum(rsdtjssdl) rsdtjssdl,sum(rxnssdl) rxnssdl,sum(rcwsldwssdl) rcwsldwssdl,sum(rcwsltqssdl) rcwsltqssdl";
         qw.ge("record_date", DateUtils.parseDate(beginDate)).le("record_date", DateUtils.parseDate(endDate));
+
         if (companys.endsWith("RGN")) {
+            qw.select("region_id id" + sql);
             qw.eq("region_id", companys);
+            qw.groupBy("region_id");
         } else {
+            qw.select("company_id id" + sql);
             qw.eq("company_id", companys);
+            qw.groupBy("region_id");
         }
         if (type.equals("-1")) {
             qw.like("windturbine_id", "_WT_");
         } else {
             qw.like("windturbine_id", "_IN_");
         }
-        qw.groupBy("record_date");
-        List<WxsslVo> wxsslVoList = getWxsslSortVos(qw, resultList, TYPE_DATE);
+
+        List<WxsslVo> wxsslVoList = getWxsslSortVos(qw, resultList, TYPE_COMPANY);
         if (StringUtils.isNotEmpty(target) && StringUtils.isNotEmpty(sort)) {
             if (sort.equals("1")) {
                 SortUtils.sort(resultList, target, SortUtils.ASC);
@@ -932,7 +947,7 @@ public class BenchmarkingService {
     public List<WxsslVo> zqdb(String companys, String type, String wpids, String projectids, String lineids, String squareids, String beginDate, String endDate, String target, String sort) {
         List<WxsslVo> resultList = new ArrayList<>();
         QueryWrapper<ProEconEquipmentInfoDay1> qw = new QueryWrapper<>();
-        qw.select("line_id,sum(rfdl) rfdl,sum(rllfdl) rllfdl,avg(rpjfs) rpjfs,sum(rjxssdl) rjxssdl,sum(rcnsljxssdl) rcnsljxssdl,sum(rgzssdl) rgzssdl,sum(rcnslgzssdl) rcnslgzssdl,sum(rxdtjssdl) rxdtjssdl,sum(rxdjclssdl) rxdjclssdl,sum(rdjssdl) rdjssdl,sum(rqxjclssdl) rqxjclssdl,sum(rsdtjssdl) rsdtjssdl,sum(rxnssdl) rxnssdl,sum(rcwsldwssdl) rcwsldwssdl,sum(rcwsltqssdl) rcwsltqssdl");
+        qw.select("square_id,sum(rfdl) rfdl,sum(rllfdl) rllfdl,avg(rpjfs) rpjfs,sum(rjxssdl) rjxssdl,sum(rcnsljxssdl) rcnsljxssdl,sum(rgzssdl) rgzssdl,sum(rcnslgzssdl) rcnslgzssdl,sum(rxdtjssdl) rxdtjssdl,sum(rxdjclssdl) rxdjclssdl,sum(rdjssdl) rdjssdl,sum(rqxjclssdl) rqxjclssdl,sum(rsdtjssdl) rsdtjssdl,sum(rxnssdl) rxnssdl,sum(rcwsldwssdl) rcwsldwssdl,sum(rcwsltqssdl) rcwsltqssdl");
 
         qw.ge("record_date", DateUtils.parseDate(beginDate)).le("record_date", DateUtils.parseDate(endDate));
 
@@ -961,7 +976,7 @@ public class BenchmarkingService {
             qw.like("windturbine_id", "_IN_");
         }
         qw.groupBy("square_id");
-        List<WxsslVo> wxsslVoList = getWxsslSortVos(qw, resultList, TYPE_LINE);
+        List<WxsslVo> wxsslVoList = getWxsslSortVos(qw, resultList, TYPE_SQUARE);
         if (StringUtils.isNotEmpty(target) && StringUtils.isNotEmpty(sort)) {
             if (sort.equals("1")) {
                 SortUtils.sort(resultList, target, SortUtils.ASC);