feat(零碳): 长庆

1.长庆演示首页功能开发,新增采油厂统计信息查询接口,添加线上接口并完成接口冒烟测试;
2.长庆演示首页功能开发,新增线路图查询接口,添加线上接口并完成接口冒烟测试;
3.长庆演示首页功能开发,新增线路详情查询接口,添加线上接口并完成接口冒烟测试;
4.对接第三方接口,完成获取井场日累计数据接口调用,创建数据表,同时生成对应代码,开发定时任务及对外接口,完成第三方数据接入及系统展示功能,添加线上接口文档并完成接口及定时任务冒烟测试;
5.对接第三方接口,完成获取第三方单井平均有功功率接口调用,创建数据表,同时生成对应代码,开发定时任务及对外接口,完成第三方数据接入及系统展示功能,添加线上接口文档并完成接口及定时任务冒烟测试;

BREAKING CHANGE: 无

Closes 无

[skip ci]

C09-base/pps-cloud-base/src/main/java/pps/cloud/base/service/data/base_power_line_plant/DynamicQueryBasePowerLinePlantViewOutput.java

@@ -20,6 +20,13 @@ public class DynamicQueryBasePowerLinePlantViewOutput {
     @XText("线路ID")
     private String lineId;
 
+    /**
+     * 电站名称
+     */
+    @XText("电站名称")
+    private String stationName;
+
+
     /**
      * 装机总量
      */

C12-prediction/pps-core-prediction/src/main/java/pps/core/prediction/mapper/EnergyConsumptionAnalysisMapper.java

@@ -5,7 +5,7 @@ import org.springframework.stereotype.Repository;
 import pps.core.prediction.entity.EnergyConsumptionAnalysisEnt;
 
 /**
- * 能耗分析表(测试用)
+ * 能耗分析表
  *
  * @author ZWT
  * @date 2023/11/23

C12-prediction/pps-core-prediction/src/main/java/pps/core/prediction/mapper/EnergyConsumptionAnalysisViewMapper.java

@@ -7,7 +7,7 @@ import pps.core.prediction.entity.EnergyConsumptionAnalysisView;
 import java.util.List;
 
 /**
- * 能耗分析表(测试用)
+ * 能耗分析表
  *
  * @author ZWT
  * @date 2023/11/23

C12-prediction/pps-core-prediction/src/main/java/pps/core/prediction/service/HomePageService.java

@@ -582,26 +582,24 @@ public class HomePageService {
         if (CollUtil.isNotEmpty(plantViewList)) {
             areaName = this.getSysAreaPath(context, plantViewList.get(0).getAreaCode());
         }
-        BigDecimal cumulativeProduction = BigDecimal.ZERO;
-        try {
-            //实时站
-            String stationResult = ServiceUtil.doPostFormCq(context,
-                    ThirdPartyApiConstant.CQ_GROUP_REAL_PV_DATA,
-                    new HashMap<>(0));
-            List<GetCumulativePowerGenerationOutput> stationList = JSON.parseArray(stationResult, GetCumulativePowerGenerationOutput.class);
-            if (CollUtil.isNotEmpty(stationList)) {
-                Set<String> set = this.getLineList(context, null, null, input.getLineId()).stream()
-                        .map(DynamicQueryBasePowerLineOutput::getLineName)
-                        .collect(Collectors.toSet());
-                for (GetCumulativePowerGenerationOutput station : stationList) {
-                    if (set.contains(station.getStationName())) {
-                        cumulativeProduction = cumulativeProduction.add(station.getDailyLiquidProduction());
-                    }
-                }
-            }
-        } catch (Exception e) {
-            context.getLogger().error(e);
-        }
+        //查平均产液量
+        WellheadDailyProductionSituationMapper mapper = context.getBean(WellheadDailyProductionSituationMapper.class);
+        BigDecimal cumulativeProduction = mapper.selectOne(new QueryWrapper<WellheadDailyProductionSituationEnt>()
+                .select("IFNULL( AVG( daily_liquid_production ), 0 ) AS daily_liquid_production ")
+                .lambda()
+                .in(WellheadDailyProductionSituationEnt::getWellNumber, wellheadList.stream()
+                        .map(DynamicQueryBasePowerLineWellheadViewOutput::getWellNumber)
+                        .collect(Collectors.toList()))
+        ).getDailyLiquidProduction();
+        //查平均发电量
+        EnergyConsumptionAnalysisMapper analysisMapper = context.getBean(EnergyConsumptionAnalysisMapper.class);
+        BigDecimal powerGeneration = analysisMapper.selectOne(new QueryWrapper<EnergyConsumptionAnalysisEnt>()
+                .select("IFNULL( AVG( power_generation ), 0 ) AS power_generation ")
+                .lambda()
+                .in(EnergyConsumptionAnalysisEnt::getStationName, plantViewList.stream()
+                        .map(DynamicQueryBasePowerLinePlantViewOutput::getStationName)
+                        .collect(Collectors.toList()))
+        ).getPowerGeneration();
         return XSingleResult.success(GetLineViewOutput.builder()
                 .wellList(wellheadList)
                 .operatingLoad(operatingLoad)
@@ -609,7 +607,7 @@ public class HomePageService {
                 .photovoltaicPower(plantViewList.stream()
                         .map(DynamicQueryBasePowerLinePlantViewOutput::getTotalPower)
                         .reduce(BigDecimal.ZERO, BigDecimal::add))
-                .powerGeneration(BigDecimal.ZERO)
+                .powerGeneration(powerGeneration)
                 .areaName(areaName)
                 .build());
     }