Commit 8c7f8a2e authored by ZWT's avatar ZWT

feat(吉林演示): 松原

1.修改系统首页大屏总览接口,增加区分组织机构逻辑,完成接口冒烟测试;
2.修改系统首页获取井场列表接口,增加区分组织机构逻辑,完成接口冒烟测试;
3.修改系统首页井场功能下钻后提示报错问题,修改用电功率数据获取逻辑,修复报错问题;
4.修改输电线路分页列表查询接口,增加查询条件,在查询父线路列表时只查询10千伏线路,修改线上接口文档同时完成接口冒烟测试;
5.修改系统首页井场实时监控接口,增加区分组织机构逻辑,完成接口冒烟测试;
6.修改系统首页用能分析接口,增加区分组织机构逻辑,完成接口冒烟测试;
7.修改系统首页井场用能分析(双坐标轴)接口,增加区分组织机构逻辑,完成接口冒烟测试;
8.修改系统首页累积用电接口,增加区分组织机构逻辑,完成接口冒烟测试;
9.修改系统首页光伏实时监控接口,增加区分组织机构逻辑,完成接口冒烟测试;
10.修改系统首页井场效果评价接口,增加区分组织机构逻辑,完成接口冒烟测试;
11.修改系统首页先导实验井间开制度接口,增加区分组织机构逻辑,完成接口冒烟测试;
12.修改极短期间开优化模块井口生产情况油井状态接口,增加区分组织机构逻辑,完成接口冒烟测试;

BREAKING CHANGE: 无

Closes 无

[skip ci]
parent 1ce57949
...@@ -49,4 +49,8 @@ public class EnergyConsumptionAnalysisEnt implements Serializable { ...@@ -49,4 +49,8 @@ public class EnergyConsumptionAnalysisEnt implements Serializable {
@XText("日期") @XText("日期")
@TableField @TableField
private Date dataDate; private Date dataDate;
@XText("来源系统")
@TableField
private String systemSource;
} }
...@@ -386,7 +386,7 @@ public class EnergyConsumptionAnalysisService { ...@@ -386,7 +386,7 @@ public class EnergyConsumptionAnalysisService {
//井场额定功率 //井场额定功率
BigDecimal operatingLoad = BigDecimal.ZERO; BigDecimal operatingLoad = BigDecimal.ZERO;
//开井数量 //开井数量
Integer openWellNumber; int openWellNumber;
//日累计产液量(m³) //日累计产液量(m³)
BigDecimal dailyLiquidProduction; BigDecimal dailyLiquidProduction;
//日累计用电量(KW·h) //日累计用电量(KW·h)
...@@ -403,7 +403,7 @@ public class EnergyConsumptionAnalysisService { ...@@ -403,7 +403,7 @@ public class EnergyConsumptionAnalysisService {
.build()); .build());
Set<String> plantSet = new HashSet<>(plantList.size()); Set<String> plantSet = new HashSet<>(plantList.size());
for (DynamicQueryBasePowerLinePlantViewOutput plant : plantList) { for (DynamicQueryBasePowerLinePlantViewOutput plant : plantList) {
photovoltaicPower.add(plant.getTotalPower()); photovoltaicPower = photovoltaicPower.add(plant.getTotalPower());
plantSet.add(plant.getStationName()); plantSet.add(plant.getStationName());
} }
DateTime today = DateUtil.beginOfDay(DateUtil.date()); DateTime today = DateUtil.beginOfDay(DateUtil.date());
...@@ -438,7 +438,7 @@ public class EnergyConsumptionAnalysisService { ...@@ -438,7 +438,7 @@ public class EnergyConsumptionAnalysisService {
.build()); .build());
Set<String> wellSet = new HashSet<>(wellheadList.size()); Set<String> wellSet = new HashSet<>(wellheadList.size());
for (DynamicQueryBasePowerLineWellheadViewOutput well : wellheadList) { for (DynamicQueryBasePowerLineWellheadViewOutput well : wellheadList) {
operatingLoad.add(well.getRatedPower()); operatingLoad = operatingLoad.add(well.getRatedPower());
wellSet.add(well.getWellNumber()); wellSet.add(well.getWellNumber());
} }
//用电功率 //用电功率
...@@ -640,7 +640,7 @@ public class EnergyConsumptionAnalysisService { ...@@ -640,7 +640,7 @@ public class EnergyConsumptionAnalysisService {
for (int i = 0; i < 24; i++) { for (int i = 0; i < 24; i++) {
String value = String.valueOf(i); String value = String.valueOf(i);
predictPower = shortMap.getOrDefault(value, BigDecimal.ZERO); predictPower = shortMap.getOrDefault(value, BigDecimal.ZERO);
actualPower = powerMap.getOrDefault(value, BigDecimal.ZERO); actualPower = powerMap.getOrDefault(i, BigDecimal.ZERO);
outputs.add( outputs.add(
GetPredictedPowerContrastOutput.builder() GetPredictedPowerContrastOutput.builder()
.hourNumber(i) .hourNumber(i)
......
...@@ -215,6 +215,7 @@ public class HomePageService { ...@@ -215,6 +215,7 @@ public class HomePageService {
"IFNULL( ROUND( SUM( daily_liquid_production ), 2 ), 0 ) AS daily_liquid_production") "IFNULL( ROUND( SUM( daily_liquid_production ), 2 ), 0 ) AS daily_liquid_production")
.lambda() .lambda()
.eq(ThirdDailyAccumulationUpdateEnt::getSaveDate, beginOfDay) .eq(ThirdDailyAccumulationUpdateEnt::getSaveDate, beginOfDay)
.eq(ThirdDailyAccumulationUpdateEnt::getSystemSource, oilFieldCode)
.in(ThirdDailyAccumulationUpdateEnt::getStationName, set) .in(ThirdDailyAccumulationUpdateEnt::getStationName, set)
); );
if (ObjectUtil.isNotNull(ent)) { if (ObjectUtil.isNotNull(ent)) {
...@@ -436,6 +437,8 @@ public class HomePageService { ...@@ -436,6 +437,8 @@ public class HomePageService {
List<GetStationPowerConsumption> stationList; List<GetStationPowerConsumption> stationList;
BigDecimal powerConsumption = BigDecimal.ZERO; BigDecimal powerConsumption = BigDecimal.ZERO;
EnergyConsumptionAnalysisMapper mapper = context.getBean(EnergyConsumptionAnalysisMapper.class); EnergyConsumptionAnalysisMapper mapper = context.getBean(EnergyConsumptionAnalysisMapper.class);
//当前配置
String oilFieldCode = ServiceUtil.getOilFieldCode(context);
if (CharSequenceUtil.isBlank(stationId)) { if (CharSequenceUtil.isBlank(stationId)) {
stationId = context.getSession(PpsUserSession.class).getOuId(); stationId = context.getSession(PpsUserSession.class).getOuId();
Map<String, String> collect = ServiceUtil.getOrgIdsByPath(context, GetAllOuListByOuIdInput.builder() Map<String, String> collect = ServiceUtil.getOrgIdsByPath(context, GetAllOuListByOuIdInput.builder()
...@@ -455,6 +458,7 @@ public class HomePageService { ...@@ -455,6 +458,7 @@ public class HomePageService {
.lambda() .lambda()
.in(EnergyConsumptionAnalysisEnt::getStationName, lineNameList) .in(EnergyConsumptionAnalysisEnt::getStationName, lineNameList)
.eq(EnergyConsumptionAnalysisEnt::getDataDate, startTime) .eq(EnergyConsumptionAnalysisEnt::getDataDate, startTime)
.eq(EnergyConsumptionAnalysisEnt::getSystemSource, oilFieldCode)
); );
stationList.add(GetStationPowerConsumption.builder() stationList.add(GetStationPowerConsumption.builder()
.stationName(collect.get(entry.getKey())) .stationName(collect.get(entry.getKey()))
...@@ -472,6 +476,7 @@ public class HomePageService { ...@@ -472,6 +476,7 @@ public class HomePageService {
.lambda() .lambda()
.in(EnergyConsumptionAnalysisEnt::getStationName, lineNameList) .in(EnergyConsumptionAnalysisEnt::getStationName, lineNameList)
.eq(EnergyConsumptionAnalysisEnt::getDataDate, startTime) .eq(EnergyConsumptionAnalysisEnt::getDataDate, startTime)
.eq(EnergyConsumptionAnalysisEnt::getSystemSource, oilFieldCode)
.groupBy(EnergyConsumptionAnalysisEnt::getStationName) .groupBy(EnergyConsumptionAnalysisEnt::getStationName)
); );
stationList = new ArrayList<>(list.size()); stationList = new ArrayList<>(list.size());
......
...@@ -8,6 +8,7 @@ ...@@ -8,6 +8,7 @@
<result column="power_generation" property="powerGeneration" jdbcType="DECIMAL"/> <result column="power_generation" property="powerGeneration" jdbcType="DECIMAL"/>
<result column="power_consumption" property="powerConsumption" jdbcType="DECIMAL"/> <result column="power_consumption" property="powerConsumption" jdbcType="DECIMAL"/>
<result column="data_date" property="dataDate" jdbcType="DATE"/> <result column="data_date" property="dataDate" jdbcType="DATE"/>
<result column="system_source" property="systemSource" jdbcType="VARCHAR"/>
</resultMap> </resultMap>
<sql id="Base_Column_List"> <sql id="Base_Column_List">
id id
...@@ -16,7 +17,8 @@ ...@@ -16,7 +17,8 @@
line_id, line_id,
power_generation, power_generation,
power_consumption, power_consumption,
data_date data_date,
system_source
</sql> </sql>
<select id="selectOne" parameterType="pps.core.prediction.entity.EnergyConsumptionAnalysisView" <select id="selectOne" parameterType="pps.core.prediction.entity.EnergyConsumptionAnalysisView"
resultMap="BaseResultMap"> resultMap="BaseResultMap">
......
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