feat(零碳): 长庆

1.长庆演示首页功能开发,新增查询井场/场站列表接口,添加接口文档并完成接口冒烟测试;
2.长庆演示首页功能开发,新增总览信息统计接口,添加接口文档并完成接口冒烟测试;

BREAKING CHANGE: 无

Closes 无

[skip ci]

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

 package pps.core.prediction.service;
 
 import cn.hutool.core.text.CharSequenceUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import pps.cloud.base.service.BasePhotovoltaicPlantCloudService;
 import pps.cloud.base.service.IBaseEnergyStorageCloudService;
 import pps.cloud.base.service.IBasePowerLineCloudService;
@@ -15,6 +16,8 @@ import pps.cloud.base.service.data.base_wellhead.DynamicQueryBaseWellheadInput;
 import pps.cloud.base.service.data.base_wellhead.DynamicQueryBaseWellheadOutput;
 import pps.cloud.system.service.SysOrganizationCloudService;
 import pps.cloud.system.service.data.GetSysOrganizationViewOutput;
+import pps.core.prediction.entity.ThirdCurrentWellConditionEnt;
+import pps.core.prediction.mapper.ThirdCurrentWellConditionMapper;
 import pps.core.prediction.service.data.home_page.GetOverviewViewOutput;
 import pps.core.prediction.service.data.home_page.GetStationViewInput;
 import pps.core.prediction.service.data.home_page.GetStationViewOutput;
@@ -30,6 +33,7 @@ import xstartup.feature.api.annotation.XApiGet;
 import java.math.BigDecimal;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * 首页
@@ -128,10 +132,24 @@ public class HomePageService {
     @XText("首页模块--井场实时监控")
     @XApiGet
     public XSingleResult<GetWellOverviewViewOutput> getWellOverview(XContext context, GetStationViewInput input) {
-
-        return XSingleResult.success();
+        String stationId = input.getStationId();
+        List<DynamicQueryBaseWellheadOutput> wellList = this.getWellList(context, stationId);
+        ThirdCurrentWellConditionMapper mapper = context.getBean(ThirdCurrentWellConditionMapper.class);
+        List<ThirdCurrentWellConditionEnt> thirdCurrentWellList = mapper.selectList(new LambdaQueryWrapper<ThirdCurrentWellConditionEnt>()
+                .in(ThirdCurrentWellConditionEnt::getWellNumber, wellList.stream()
+                        .map(DynamicQueryBaseWellheadOutput::getWellNumber)
+                        .collect(Collectors.toList()))
+        );
+        int openWellNumber = 0;
+        int stopWellNumber = 0;
+        return XSingleResult.success(GetWellOverviewViewOutput.builder()
+                .openWellNumber(openWellNumber)
+                .stopWellNumber(stopWellNumber)
+                .build());
     }
 
+
+
     /*------------------------------------------------- private ---------------------------------------------------------*/
 
     /**