feat(零碳): 长庆

1.长庆演示首页功能开发,新增查询井场/场站列表接口,添加接口文档并完成接口冒烟测试;
2.长庆演示首页功能开发,新增总览信息统计接口,添加接口文档并完成接口冒烟测试;
3.长庆演示首页功能开发,新增用能分析统计接口,添加接口文档并完成接口冒烟测试;
4.长庆演示首页功能开发,新增累计用电统计接口,添加接口文档并完成接口冒烟测试;
5.长庆演示首页功能开发,新增光伏实时监控统计接口,添加接口文档并完成接口冒烟测试;
6.长庆演示首页功能开发,新增先导实验井间开制度统计接口,添加接口文档并完成接口冒烟测试;
7.长庆演示首页功能开发,新增零碳井场收益分析统计接口,添加接口文档并完成接口冒烟测试;
8.长庆演示首页功能开发,新增零碳井场实时监控接口,添加接口文档并完成接口冒烟测试;

BREAKING CHANGE: 无

Closes 无

[skip ci]

C11-space/pps-core-space/src/main/java/pps/core/space/service/SpaceInstitutionDetailService.java

@@ -10,6 +10,8 @@ import com.github.pagehelper.PageInfo;
 import com.github.pagehelper.page.PageMethod;
 import org.apache.commons.lang3.StringUtils;
 import pps.cloud.base.service.IBasePowerLineCloudService;
+import pps.cloud.base.service.data.base_power_line.GetBasePowerLineInput;
+import pps.cloud.base.service.data.base_power_line.GetBasePowerLineViewOutput;
 import pps.cloud.base.service.data.base_power_line_wellhead.DynamicQueryBasePowerLineWellheadInput;
 import pps.cloud.base.service.data.base_power_line_wellhead.DynamicQueryBasePowerLineWellheadViewOutput;
 import pps.core.common.constant.BusinessConstant;
@@ -76,11 +78,13 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService {
     @XText("基础间开配置--新增")
     public XServiceResult createSpaceInstitutionDetail(XContext context, CreateSpaceInstitutionDetailInput input) {
         PpsUserSession session = context.getSession(PpsUserSession.class);
+        GetBasePowerLineViewOutput lineById = this.getBasePowerLineById(context, input.getLineId());
+        input.setOuId(lineById.getOuId());
+        SpaceInstitutionDetailEnt entity = XCopyUtils.copyNewObject(input, SpaceInstitutionDetailEnt.class);
+        BaseUtils.setBaseModelDefault(entity, session);
         return XTransactionHelper.begin(context, () -> {
             //新增间开配置
             SpaceInstitutionDetailMapper mapper = context.getBean(SpaceInstitutionDetailMapper.class);
-            SpaceInstitutionDetailEnt entity = XCopyUtils.copyNewObject(input, SpaceInstitutionDetailEnt.class);
-            BaseUtils.setBaseModelDefault(entity, session);
             mapper.insert(entity);
             String institutionId = entity.getId();
             List<CreateSpaceInstitutionWellheadInput> wellheadList = input.getWellheadList();
@@ -102,16 +106,18 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService {
     @XText("基础间开配置--修改")
     public XServiceResult updateSpaceInstitutionDetail(XContext context, UpdateSpaceInstitutionDetailInput input) {
         String institutionId = input.getId();
+        GetBasePowerLineViewOutput lineById = this.getBasePowerLineById(context, input.getLineId());
+        input.setOuId(lineById.getOuId());
+        SpaceInstitutionDetailMapper mapper = context.getBean(SpaceInstitutionDetailMapper.class);
+        SpaceInstitutionDetailEnt entity = this.getInstitutionDetail(mapper, institutionId);
+        if (Objects.isNull(entity)) {
+            return XServiceResult.error(context, XError.NotFound);
+        }
+        Integer isCurrentBasic = entity.getIsCurrentBasic();
+        if (isCurrentBasic.equals(0)) {
+            return XServiceResult.error(context, BusinessError.CannotBeDeleted);
+        }
         return XTransactionHelper.begin(context, () -> {
-            SpaceInstitutionDetailMapper mapper = context.getBean(SpaceInstitutionDetailMapper.class);
-            SpaceInstitutionDetailEnt entity = this.getInstitutionDetail(mapper, institutionId);
-            if (Objects.isNull(entity)) {
-                return XServiceResult.error(context, XError.NotFound);
-            }
-            Integer isCurrentBasic = entity.getIsCurrentBasic();
-            if (isCurrentBasic.equals(0)) {
-                return XServiceResult.error(context, BusinessError.CannotBeDeleted);
-            }
             PpsUserSession session = context.getSession(PpsUserSession.class);
             this.updateInstitutionDetail(context, session, mapper, institutionId, input, entity);
             return XServiceResult.OK;
@@ -755,4 +761,20 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService {
         BaseUtils.setBaseModelDefault(entity, session);
         mapper.updateById(entity);
     }
+
+    /**
+     * 通过id获取基本电源线
+     *
+     * @param context 上下文
+     * @param lineId  线路id
+     * @return {@link GetBasePowerLineViewOutput}
+     */
+    private GetBasePowerLineViewOutput getBasePowerLineById(XContext context, String lineId) {
+        IBasePowerLineCloudService bean = context.getBean(IBasePowerLineCloudService.class);
+        XSingleResult<GetBasePowerLineViewOutput> result = bean.getBasePowerLineById(context, GetBasePowerLineInput.builder()
+                .id(lineId)
+                .build());
+        result.throwIfFail();
+        return result.getResult();
+    }
 }
\ No newline at end of file