Commit abcc5d2a authored by ZWT's avatar ZWT

feat(能源管理系统): 间开制度管理

1.开发间开制度管理-基础间开配置模块新增功能,完成接口冒烟测试并生成接口文档;
2.排查无法获取mapper对象导致空指针异常问题,space模块添加mapper配置类;
3.开发间开制度管理-基础间开配置模块修改功能,完成接口冒烟测试并生成接口文档;
4.开发间开制度管理-基础间开配置模块逻辑删除功能,完成接口冒烟测试并生成接口文档;
5.开发间开制度管理-基础间开配置模块详情功能,完成接口冒烟测试并生成接口文档;
6.开发基础信息管理-输电线路Cloud模块通过ID查询线路基本信息功能;

BREAKING CHANGE: 无

Closes 无

[skip ci]
parent ab87f44e
package pps.cloud.base.service.data.base_power_line; package pps.cloud.base.service.data.base_power_line;
import jakarta.validation.constraints.NotBlank; import jakarta.validation.constraints.NotBlank;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import xstartup.annotation.XText; import xstartup.annotation.XText;
/** /**
...@@ -11,6 +14,9 @@ import xstartup.annotation.XText; ...@@ -11,6 +14,9 @@ import xstartup.annotation.XText;
* @date 2023/08/28 * @date 2023/08/28
*/ */
@Data @Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
public class GetBasePowerLineInput { public class GetBasePowerLineInput {
@XText("ID") @XText("ID")
......
...@@ -2,6 +2,8 @@ package pps.core.base.service.impl; ...@@ -2,6 +2,8 @@ package pps.core.base.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import pps.cloud.base.service.BasePowerLineCloudService; import pps.cloud.base.service.BasePowerLineCloudService;
import pps.cloud.base.service.data.base_power_line.GetBasePowerLineInput;
import pps.cloud.base.service.data.base_power_line.GetBasePowerLineViewOutput;
import pps.core.base.entity.BasePowerLineEnt; import pps.core.base.entity.BasePowerLineEnt;
import pps.core.base.mapper.BasePowerLineMapper; import pps.core.base.mapper.BasePowerLineMapper;
import pps.core.common.entity.BaseModel; import pps.core.common.entity.BaseModel;
......
...@@ -13,7 +13,9 @@ import pps.core.common.utils.BaseUtils; ...@@ -13,7 +13,9 @@ import pps.core.common.utils.BaseUtils;
import pps.core.space.entity.*; import pps.core.space.entity.*;
import pps.core.space.mapper.*; import pps.core.space.mapper.*;
import pps.core.space.service.data.space_institution_detail.*; import pps.core.space.service.data.space_institution_detail.*;
import pps.core.space.service.data.space_institution_duration.GetSpaceInstitutionDurationViewOutput;
import pps.core.space.service.data.space_institution_wellhead.CreateSpaceInstitutionWellheadInput; import pps.core.space.service.data.space_institution_wellhead.CreateSpaceInstitutionWellheadInput;
import pps.core.space.service.data.space_institution_wellhead.GetSpaceInstitutionWellheadViewOutput;
import pps.core.space.service.data.space_institution_wellhead.UpdateSpaceInstitutionWellheadInput; import pps.core.space.service.data.space_institution_wellhead.UpdateSpaceInstitutionWellheadInput;
import pps.core.space.utils.ServiceUtil; import pps.core.space.utils.ServiceUtil;
import xstartup.annotation.XService; import xstartup.annotation.XService;
...@@ -31,10 +33,8 @@ import xstartup.feature.api.annotation.XApiPost; ...@@ -31,10 +33,8 @@ import xstartup.feature.api.annotation.XApiPost;
import xstartup.feature.mybatis.helper.XMapperHelper; import xstartup.feature.mybatis.helper.XMapperHelper;
import xstartup.helper.XTransactionHelper; import xstartup.helper.XTransactionHelper;
import java.util.Date; import java.util.*;
import java.util.List; import java.util.stream.Collectors;
import java.util.Map;
import java.util.Objects;
/** /**
* 基础间开配置模块 * 基础间开配置模块
...@@ -195,13 +195,45 @@ public class SpaceInstitutionDetailService { ...@@ -195,13 +195,45 @@ public class SpaceInstitutionDetailService {
return XSingleResult.error(context, XError.NotFound); return XSingleResult.error(context, XError.NotFound);
} }
GetSpaceInstitutionDetailViewOutput output = XCopyUtils.copyNewObject(entity, GetSpaceInstitutionDetailViewOutput.class); GetSpaceInstitutionDetailViewOutput output = XCopyUtils.copyNewObject(entity, GetSpaceInstitutionDetailViewOutput.class);
SpaceInstitutionWellheadMapper wellheadMapper = context.getBean(SpaceInstitutionWellheadMapper.class); SpaceInstitutionWellheadMapper wellheadMapper = context.getBean(SpaceInstitutionWellheadMapper.class);
//查井口列表
List<SpaceInstitutionWellheadEnt> wellheadEntList = wellheadMapper.selectList(new LambdaQueryWrapper<SpaceInstitutionWellheadEnt>()
.eq(SpaceInstitutionWellheadEnt::getInstitutionId, institutionId)
.orderByAsc(SpaceInstitutionWellheadEnt::getStartSeq)
);
if (CollUtil.isNotEmpty(wellheadEntList)) {
List<GetSpaceInstitutionWellheadViewOutput> wellheadViewOutputs = XCopyUtils.copyNewList(wellheadEntList, GetSpaceInstitutionWellheadViewOutput.class);
Map<String, String> runTypeMap = ServiceUtil.getDictMap(context, BusinessConstant.RUN_TYPE);
Map<String, String> intervalTypeMap = ServiceUtil.getDictMap(context, BusinessConstant.INTERVAL_TYPE);
wellheadViewOutputs.forEach(wellhead -> {
wellhead.setRunTypeName(runTypeMap.get(wellhead.getRunTypeKey()));
wellhead.setIntervalTypeName(intervalTypeMap.get(wellhead.getIntervalTypeKey()));
});
//查时段列表
SpaceInstitutionDurationMapper durationMapper = context.getBean(SpaceInstitutionDurationMapper.class); SpaceInstitutionDurationMapper durationMapper = context.getBean(SpaceInstitutionDurationMapper.class);
List<SpaceInstitutionDurationEnt> durationEntList = durationMapper.selectList(new LambdaQueryWrapper<SpaceInstitutionDurationEnt>()
Map<String, String> gridTypeMap = ServiceUtil.getDictMap(context, BusinessConstant.GRID_TYPE); .eq(SpaceInstitutionDurationEnt::getInstitutionId, institutionId)
Map<String, String> lineTypeMap = ServiceUtil.getDictMap(context, BusinessConstant.LINE_TYPE); .orderByAsc(SpaceInstitutionDurationEnt::getOpenWellTime)
GetBasePowerLineViewOutput basePowerLineById = ServiceUtil.getBasePowerLineById(context, entity.getLineId()); );
if (CollUtil.isNotEmpty(durationEntList)) {
List<GetSpaceInstitutionDurationViewOutput> durationViewOutputList = XCopyUtils.copyNewList(durationEntList, GetSpaceInstitutionDurationViewOutput.class);
Map<String, List<GetSpaceInstitutionDurationViewOutput>> collect = durationViewOutputList.stream()
.collect(Collectors.groupingBy(GetSpaceInstitutionDurationViewOutput::getWellheadId));
wellheadViewOutputs.forEach(wellhead -> {
String wellheadId = wellhead.getWellheadId();
if (collect.containsKey(wellheadId)) {
wellhead.setDurationList(collect.get(wellheadId));
} else {
wellhead.setDurationList(new ArrayList<>(0));
}
});
}
output.setWellheadList(wellheadViewOutputs);
} else {
output.setWellheadList(new ArrayList<>(0));
}
output.setOuName(ServiceUtil.getSysOrgNameById(context, output.getOuId()));
output.setGridTypeName(ServiceUtil.getDictMap(context, BusinessConstant.GRID_TYPE).get(output.getGridTypeKey()));
return XSingleResult.success(output); return XSingleResult.success(output);
} }
......
package pps.core.space.service.data.space_institution_duration; package pps.core.space.service.data.space_institution_duration;
import com.baomidou.mybatisplus.annotation.TableField;
import lombok.Data; import lombok.Data;
import xstartup.annotation.XText; import xstartup.annotation.XText;
...@@ -12,6 +13,10 @@ import xstartup.annotation.XText; ...@@ -12,6 +13,10 @@ import xstartup.annotation.XText;
@Data @Data
public class GetSpaceInstitutionDurationViewOutput { public class GetSpaceInstitutionDurationViewOutput {
@XText("井口ID")
@TableField
private String wellheadId;
@XText("开井时间") @XText("开井时间")
private String openWellTime; private String openWellTime;
......
package pps.core.space.utils; package pps.core.space.utils;
import pps.cloud.base.service.BasePowerLineCloudService; import pps.cloud.base.service.BasePowerLineCloudService;
import pps.cloud.base.service.data.base_power_line.GetBasePowerLineInput;
import pps.cloud.base.service.data.base_power_line.GetBasePowerLineViewOutput;
import pps.cloud.system.service.SysOrganizationCloudService; import pps.cloud.system.service.SysOrganizationCloudService;
import pps.cloud.system.service.SystemAreaService; import pps.cloud.system.service.SystemAreaService;
import pps.cloud.system.service.SystemDictionaryService; import pps.cloud.system.service.SystemDictionaryService;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment