品牌对标提交

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

@@ -517,4 +517,42 @@ public class BenchmarkingController {
         }
     }
 
+    @GetMapping(value = "/modellist")
+    @ApiOperation(value = "型号列表", notes = "型号列表")
+    public R modellist(@RequestParam(value = "wpids", required = true) String wpids)  {
+
+        List<ProBasicOrganizeTree> resultList = benchmarkingService.modellist(wpids);
+        if (StringUtils.isNotNull(resultList)) {
+            return R.data(ResultMsg.ok(resultList));
+        } else {
+            return R.error(ResultMsg.error());
+        }
+    }
+
+    @GetMapping("/ppdb")
+    @ResponseBody
+    @ApiOperation(value = "品牌对标", notes = "品牌对标")
+    public R ppdb(@RequestParam(value = "companys",required = true) String companys,
+                  @RequestParam(value = "type",required = true) String type,
+                  @RequestParam(value = "wpids",required = true) String wpids,
+                  @RequestParam(value = "model",required = true) String model,
+                  @RequestParam(value = "projectids",required = true) String projectids,
+                  @RequestParam(value = "lineids",required = true) String lineids,
+                  @RequestParam(value = "squareids",required = true) String squareids,
+                  @RequestParam(value = "windturbineids",required = false) String windturbineids,
+                  @RequestParam(value = "beginDate",required = true) String beginDate,
+                  @RequestParam(value = "endDate",required = true) String endDate,
+                  @RequestParam(value = "target",required = false) String target,
+                  @RequestParam(value = "sort",required = false) String sort
+    ){
+        List<WxsslVo> resultList = benchmarkingService.ppdb(companys,type,wpids,model,projectids,lineids,squareids,windturbineids,beginDate,endDate,target,sort);
+
+        if (StringUtils.isNotNull(resultList)) {
+            return R.data(ResultMsg.ok(resultList));
+        } else {
+            return R.error(ResultMsg.error());
+        }
+    }
+
+
 }

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

@@ -121,6 +121,10 @@ public class BenchmarkingService {
                 oe -> wpids.contains(oe.getWindpowerstationId())||(oe.getNemName().contains("风机"))).collect(Collectors.toList());
     }
 
+    public List<ProBasicOrganizeTree> modellist(String wpids) {
+        return CacheContext.wtls.stream().filter(wt -> wt.getOrgType().equals("EQ") && wt.getPcodes().contains(wpids)).collect(Collectors.toList());
+    }
+
     public List<FjjxbVo> performance(String companyid, String getype, String sttype, String beginDate, String endDate, String wpids, String projectids, String lineids, String target, String sort) {
         List<FjjxbVo> resultList = new ArrayList<>();
         QueryWrapper<ProEconEquipmentInfoDay1> qw = new QueryWrapper<>();
@@ -1175,4 +1179,188 @@ public class BenchmarkingService {
         }
         return wxsslVoList;
     }
+
+
+    /**
+     * 设备对标
+     */
+    public List<WxsslVo> ppdb(String companys, String type, String wpids,String model, String projectids, String lineids, String squareids, String windturbineids, String beginDate, String endDate, String target, String sort) {
+        List<WxsslVo> resultList = new ArrayList<>();
+        QueryWrapper<ProEconEquipmentInfoDay1> qw = new QueryWrapper<>();
+        qw.select("windturbine_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));
+
+        if (StringUtils.isNotEmpty(windturbineids)) {
+            List<String> equipmentidsList = Arrays.asList(windturbineids.split(","));
+            qw.in("windturbine_id", equipmentidsList);
+        } else if (StringUtils.isNotEmpty(squareids)) {
+            List<String> squareidList = Arrays.asList(squareids.split(","));
+            qw.in("square_id", squareidList);
+        } else if (StringUtils.isNotEmpty(lineids)) {
+            List<String> lineList = Arrays.asList(lineids.split(","));
+            qw.in("line_id", lineList).isNotNull("square_id").ne("square_id", "");
+        } else if (StringUtils.isNotEmpty(projectids)) {
+            List<String> projectList = Arrays.asList(projectids.split(","));
+            qw.in("project_id", projectList).isNotNull("square_id").ne("square_id", "");
+        } else if (StringUtils.isNotEmpty(wpids)) {
+            List<String> wpList = Arrays.asList(wpids.split(","));
+            qw.in("windpowerstation_id", wpList).isNotNull("square_id").ne("square_id", "");
+        } else if (StringUtils.isNotEmpty(companys)) {
+            String[] split = companys.split(",");
+            if (companys.contains("RGN")) {
+                for (String s : split) {
+                    if (s.endsWith("RGN")) {
+                        companys = s;
+                    }
+                }
+                qw.eq("region_id", companys);
+            } else {
+                qw.in("company_id", Arrays.asList(split));
+            }
+        }
+        if (type.equals("-1")) {
+            qw.like("windturbine_id", "_WT_");
+        } else {
+            qw.like("windturbine_id", "_IN_");
+        }
+        qw.groupBy("windturbine_id");
+        List<WxsslVo> wxsslVoList = getxinWxsslSortVos(qw, resultList, TYPE_WINDTURBINE,model,wpids);
+        if (StringUtils.isNotEmpty(target) && StringUtils.isNotEmpty(sort)) {
+            if (sort.equals("1")) {
+                SortUtils.sort(resultList, target, SortUtils.ASC);
+            } else {
+                SortUtils.sort(resultList, target, SortUtils.DESC);
+            }
+        } else {
+            SortUtils.sort(resultList, "ordernum", SortUtils.ASC);
+        }
+        return wxsslVoList;
+    }
+
+
+    private List<WxsslVo> getxinWxsslSortVos(QueryWrapper<ProEconEquipmentInfoDay1> qw, List<WxsslVo> resultList, String type,String model,String wpids) {
+
+        Map<String, Integer> station = CacheContext.wpls
+                .stream().collect(Collectors.toMap(ProBasicOrganizeTree::getId, ProBasicOrganizeTree::getOrderNum));
+
+        List<ProBasicOrganizeTree> wtls = CacheContext.wtls.stream().filter(c -> model.equals(c.getModelId())).collect(Collectors.toList());
+
+        List<ProEconEquipmentInfoDay1> listls =proEconEquipmentInfoDay1Service.list(qw);
+
+        List<ProEconEquipmentInfoDay1> list = new ArrayList<>();
+        for (ProBasicOrganizeTree wt : wtls){
+            for (ProEconEquipmentInfoDay1 lst : listls) {
+                if (lst.getWindturbineId().equals(wt.getId())){
+                    list.add(lst);
+                }
+            }
+        }
+
+        if (!type.equals(TYPE_DATE))
+            list = list.stream().filter(a -> a.getWindpowerstationId() != null || a.getProjectId() != null ||
+                    a.getLineId() != null || a.getWindturbineId() != null || a.getSquareId() != null ||
+                    a.getId() != null).collect(Collectors.toList());
+        for (ProEconEquipmentInfoDay1 i : list) {
+            WxsslVo vo = new WxsslVo();
+
+            if (type.equals(TYPE_WIND)) {
+                vo.setId(i.getWindpowerstationId());
+                vo.setName(CacheContext.wpmap.get(i.getWindpowerstationId().trim()).getAname());
+                vo.setOrdernum(station.get(i.getWindpowerstationId()).doubleValue());
+            } else if (type.equals(TYPE_PROJECT)) {
+                vo.setId(i.getProjectId());
+                vo.setName(CacheContext.pjmap.get(i.getProjectId().trim()).getAname());
+                vo.setOrdernum(CacheContext.pjmap.get(i.getProjectId().trim()).getOrderNum().doubleValue());
+            } else if (type.equals(TYPE_LINE)) {
+                vo.setId(i.getLineId());
+                vo.setName(CacheContext.lnmap.get(i.getLineId().trim()).getAname());
+                vo.setOrdernum(CacheContext.lnmap.get(i.getLineId().trim()).getOrderNum().doubleValue());
+            } else if (type.equals(TYPE_WINDTURBINE)) {
+                vo.setId(i.getWindturbineId());
+                vo.setName(CacheContext.wtmap.get(i.getWindturbineId().trim()).getModelId());
+                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.getSquareId()).getAname());
+                vo.setOrdernum(CacheContext.proBasicOrganizeTreesMap.get(i.getSquareId()).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));
+            vo.setLlfdl(DoubleUtils.keepPrecision(i.getRllfdl() / 10000, 2));
+            vo.setJxssdl(DoubleUtils.keepPrecision((i.getRjxssdl() + i.getRcnsljxssdl()) / 10000, 2));
+            vo.setGzssdl(DoubleUtils.keepPrecision((i.getRgzssdl() + i.getRcnslgzssdl()) / 10000, 2));
+            vo.setXdssdl(DoubleUtils.keepPrecision((i.getRxdtjssdl() + i.getRxdjclssdl()) / 10000, 2));
+            vo.setSlssdl(DoubleUtils.keepPrecision((i.getRcwsltqssdl() + i.getRcwsldwssdl()) / 10000, 2));
+            vo.setXnssdl(DoubleUtils.keepPrecision((i.getRdjssdl() + i.getRsdtjssdl() + i.getRqxjclssdl() + i.getRxnssdl()) / 10000, 2));
+            vo.setZssdl(DoubleUtils.keepPrecision(vo.getGzssdl() + vo.getJxssdl() + vo.getXdssdl() + vo.getXnssdl() + vo.getSlssdl(), 2));
+            vo.setFnlyl(vo.getLlfdl() != 0 ? DoubleUtils.keepPrecision(vo.getFdl() / vo.getLlfdl() * 100, 2) : 0);
+            vo.setGzssl(vo.getLlfdl() != 0 ? DoubleUtils.keepPrecision(vo.getGzssdl() / vo.getLlfdl() * 100, 2) : 0);
+            vo.setJxssl(vo.getLlfdl() != 0 ? DoubleUtils.keepPrecision(vo.getJxssdl() / vo.getLlfdl() * 100, 2) : 0);
+            vo.setQfl(vo.getLlfdl() != 0 ? DoubleUtils.keepPrecision(vo.getXdssdl() / vo.getLlfdl() * 100, 2) : 0);
+            vo.setXnssl(vo.getLlfdl() != 0 ? DoubleUtils.keepPrecision(vo.getXnssdl() / vo.getLlfdl() * 100, 2) : 0);
+            vo.setSlssl(vo.getLlfdl() != 0 ? DoubleUtils.keepPrecision(vo.getSlssdl() / vo.getLlfdl() * 100, 2) : 0);
+            resultList.add(vo);
+        }
+        SortUtils.sort(resultList, "llfdl", SortUtils.DESC);
+        for (int i = 0; i < resultList.size(); i++) {
+            resultList.get(i).setZhpm(i + 1);
+        }
+        SortUtils.sort(resultList, "fdl", SortUtils.DESC);
+        for (int i = 0; i < resultList.size(); i++) {
+            resultList.get(i).setFdlpm(i + 1);
+        }
+        SortUtils.sort(resultList, "fnlyl", SortUtils.DESC);
+        for (int i = 0; i < resultList.size(); i++) {
+            resultList.get(i).setFnlylpm(i + 1);
+        }
+        SortUtils.sort(resultList, "gzssdl", SortUtils.ASC);
+        for (int i = 0; i < resultList.size(); i++) {
+            resultList.get(i).setGzssdlpm(i + 1);
+        }
+        SortUtils.sort(resultList, "gzssl", SortUtils.ASC);
+        for (int i = 0; i < resultList.size(); i++) {
+            resultList.get(i).setGzsslpm(i + 1);
+        }
+        SortUtils.sort(resultList, "jxssdl", SortUtils.ASC);
+        for (int i = 0; i < resultList.size(); i++) {
+            resultList.get(i).setJxssdlpm(i + 1);
+        }
+        SortUtils.sort(resultList, "jxssl", SortUtils.ASC);
+        for (int i = 0; i < resultList.size(); i++) {
+            resultList.get(i).setJxsslpm(i + 1);
+        }
+        SortUtils.sort(resultList, "xdssdl", SortUtils.ASC);
+        for (int i = 0; i < resultList.size(); i++) {
+            resultList.get(i).setXdssdlpm(i + 1);
+        }
+        SortUtils.sort(resultList, "qfl", SortUtils.ASC);
+        for (int i = 0; i < resultList.size(); i++) {
+            resultList.get(i).setQflpm(i + 1);
+        }
+        SortUtils.sort(resultList, "xnssdl", SortUtils.ASC);
+        for (int i = 0; i < resultList.size(); i++) {
+            resultList.get(i).setXnssdlpm(i + 1);
+        }
+        SortUtils.sort(resultList, "xnssl", SortUtils.ASC);
+        for (int i = 0; i < resultList.size(); i++) {
+            resultList.get(i).setXnsslpm(i + 1);
+        }
+        SortUtils.sort(resultList, "slssdl", SortUtils.ASC);
+        for (int i = 0; i < resultList.size(); i++) {
+            resultList.get(i).setSlssdlpm(i + 1);
+        }
+        SortUtils.sort(resultList, "slssl", SortUtils.ASC);
+        for (int i = 0; i < resultList.size(); i++) {
+            resultList.get(i).setSlsslpm(i + 1);
+        }
+        //        SortUtils.sort(resultList,"ordernum",SortUtils.ASC);
+        return resultList;
+    }
+
 }