增加日月年发电量接口

amos-boot-system-jxiop/amos-boot-module-jxiop-bigscreen-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/MonitorFanIdxController.java

@@ -1019,6 +1019,117 @@ public class MonitorFanIdxController extends BaseController {
     }
 
 
+
+    @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
+    @ApiOperation(value = "电站排名")
+    @GetMapping("/stationRankingtype")
+    public ResponseModel stationRanking(String day,String type,String  areaCode ) {
+
+
+        LambdaQueryWrapper<StationBasic> wrapper = new LambdaQueryWrapper<>();
+
+        wrapper.eq(areaCode!=null,StationBasic::getAreaCode,areaCode);
+
+        List<StationBasic> stationBasics = stationBasicMapper.selectList(wrapper);
+
+
+
+        List<Map<String, Object>> datDataFJ = new ArrayList<>();
+        List<Map<String, Object>> monthDataFJ = new ArrayList<>();
+        List<Map<String, Object>> yearDataFJ = new ArrayList<>();
+        List<Map<String, Object>> datDataGF = new ArrayList<>();
+        List<Map<String, Object>> monthDataGF = new ArrayList<>();
+        List<Map<String, Object>> yearDataGF = new ArrayList<>();
+        for (StationBasic stationBasic : stationBasics) {
+
+            String gatewayId = stationBasic.getFanGatewayId();
+            String boosterGatewayId = stationBasic.getBoosterGatewayId();
+            String querySql = null;
+            String name = stationBasic.getStationName();
+            if (stationBasic.getStationType().equals("FDZ")) {
+                Map<String, Object> map = monitorFanIndicator.generatingCapacity(gatewayId, querySql);
+                Map<String, Object> dayMap = new HashMap<>();
+                Map<String, Object> monthMap = new HashMap<>();
+                Map<String, Object> yearMap = new HashMap<>();
+                dayMap.put("name", name);
+                dayMap.put("value", map.get("日发电量") == null ? 0 : String.format("%.4f", map.get("日发电量")));
+                dayMap.put("gateWayId", stationBasic.getFanGatewayId());
+                monthMap.put("name", name);
+                monthMap.put("value", map.get("月发电量") == null ? 0 : String.format("%.4f", map.get("月发电量")));
+                monthMap.put("gateWayId", stationBasic.getFanGatewayId());
+                yearMap.put("name", name);
+                yearMap.put("gateWayId", stationBasic.getFanGatewayId());
+                yearMap.put("value", map.get("年发电量") == null ? 0 : String.format("%.4f", map.get("年发电量")));
+                datDataFJ.add(dayMap);
+                monthDataFJ.add(monthMap);
+                yearDataFJ.add(yearMap);
+            } else {
+                querySql = "逆变器";
+                Map<String, Object> map = monitorFanIndicator.generatingCapacity(boosterGatewayId, querySql);
+                Map<String, Object> dayMap = new HashMap<>();
+                Map<String, Object> monthMap = new HashMap<>();
+                Map<String, Object> yearMap = new HashMap<>();
+                dayMap.put("name", name);
+                dayMap.put("gateWayId", stationBasic.getFanGatewayId());
+                dayMap.put("value", map.get("日发电量") == null ? 0 : String.format("%.4f", Double.parseDouble(map.get("日发电量").toString())));
+                monthMap.put("name", name);
+                monthMap.put("gateWayId", stationBasic.getFanGatewayId());
+                monthMap.put("value", map.get("月发电量") == null ? 0 : String.format("%.4f", Double.parseDouble(map.get("月发电量").toString())));
+                yearMap.put("name", name);
+                yearMap.put("gateWayId", stationBasic.getFanGatewayId());
+                yearMap.put("value", map.get("年发电量") == null ? 0 : String.format("%.4f", Double.parseDouble(map.get("年发电量").toString())));
+                datDataGF.add(dayMap);
+                monthDataGF.add(monthMap);
+                yearDataGF.add(yearMap);
+            }
+        }
+//        monitorFanIndicator.sendMqttByRanking(datDataFJ, GeneratingCapacity.DAY.getCode(), "fjpm");
+//        monitorFanIndicator.sendMqttByRanking(monthDataFJ, GeneratingCapacity.MONTH.getCode(), "fjpm");
+//        monitorFanIndicator.sendMqttByRanking(yearDataFJ, GeneratingCapacity.YEAR.getCode(), "fjpm");
+//        monitorFanIndicator.sendMqttByRanking(datDataGF, GeneratingCapacity.DAY.getCode(), "gfpm");
+//        monitorFanIndicator.sendMqttByRanking(monthDataGF, GeneratingCapacity.MONTH.getCode(), "gfpm");
+//        monitorFanIndicator.sendMqttByRanking(yearDataGF, GeneratingCapacity.YEAR.getCode(), "gfpm");
+        Page<Map<String, Object>> socialContributionDtoPage = new Page<Map<String, Object>>();
+        socialContributionDtoPage.setCurrent(1);
+        socialContributionDtoPage.setTotal(100);
+
+      if("gf".equals(type)){
+          if("0".equals(day)){
+
+
+              socialContributionDtoPage.setRecords(datDataGF);
+
+          }else  if("1".equals(day)){
+              socialContributionDtoPage.setRecords(monthDataGF);
+          } else if("2".equals(day)){
+              socialContributionDtoPage.setRecords(yearDataGF);
+          }
+      }else{
+          if("0".equals(day)){
+              socialContributionDtoPage.setRecords(datDataFJ);
+
+          }else  if("1".equals(day)){
+              socialContributionDtoPage.setRecords(monthDataFJ);
+
+          } else if("2".equals(day)){
+              socialContributionDtoPage.setRecords(yearDataFJ);
+
+          }
+      }
+
+
+        return CommonResponseUtil.success(socialContributionDtoPage);
+
+
+    }
+
+
+
+
+
+
+
+
     @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
     @ApiOperation(value = "运维数据 ")
     @GetMapping("/operationData")