Commit 1b6d7cc0 authored by ZWT's avatar ZWT

得到的

parent 3caa9722
...@@ -75,6 +75,11 @@ public class BusinessConstant { ...@@ -75,6 +75,11 @@ public class BusinessConstant {
*/ */
public static final String OPEN_WELL = "开井"; public static final String OPEN_WELL = "开井";
/**
* 停井
*/
public static final String CLOSE_WELL = "停井";
/** /**
* 井口 * 井口
*/ */
......
...@@ -2646,7 +2646,7 @@ public class SpaceOptimizeBaseService { ...@@ -2646,7 +2646,7 @@ public class SpaceOptimizeBaseService {
); );
if (CollUtil.isEmpty(durationList)) { if (CollUtil.isEmpty(durationList)) {
//没有设置时间段,无法优化 //没有设置时间段,无法优化
return new HashMap<>(0); return Collections.emptyMap();
} }
return durationList.stream() return durationList.stream()
.collect( .collect(
...@@ -2690,7 +2690,7 @@ public class SpaceOptimizeBaseService { ...@@ -2690,7 +2690,7 @@ public class SpaceOptimizeBaseService {
List<DynamicQueryBasePowerLineStorageViewOutput> list = result.getResult(); List<DynamicQueryBasePowerLineStorageViewOutput> list = result.getResult();
Map<String, List<DynamicQueryBasePowerLineStorageViewOutput>> collect; Map<String, List<DynamicQueryBasePowerLineStorageViewOutput>> collect;
if (CollUtil.isEmpty(list)) { if (CollUtil.isEmpty(list)) {
collect = new HashMap<>(0); collect = Collections.emptyMap();
} else { } else {
collect = list.stream() collect = list.stream()
.collect(Collectors.groupingBy(DynamicQueryBasePowerLineStorageViewOutput::getLineId)); .collect(Collectors.groupingBy(DynamicQueryBasePowerLineStorageViewOutput::getLineId));
...@@ -2715,7 +2715,7 @@ public class SpaceOptimizeBaseService { ...@@ -2715,7 +2715,7 @@ public class SpaceOptimizeBaseService {
List<DynamicQueryBasePowerLineStorageOutput> list = result.getResult(); List<DynamicQueryBasePowerLineStorageOutput> list = result.getResult();
Map<String, List<String>> collect; Map<String, List<String>> collect;
if (CollUtil.isEmpty(list)) { if (CollUtil.isEmpty(list)) {
collect = new HashMap<>(0); collect = Collections.emptyMap();
} else { } else {
collect = list.stream() collect = list.stream()
.collect( .collect(
......
...@@ -1625,7 +1625,7 @@ public class EnergyConsumptionAnalysisService { ...@@ -1625,7 +1625,7 @@ public class EnergyConsumptionAnalysisService {
} }
} else { } else {
nextOpen = BigDecimal.ZERO; nextOpen = BigDecimal.ZERO;
currentWellStatus = "停井"; currentWellStatus = BusinessConstant.CLOSE_WELL;
if (!CharSequenceUtil.equals(currentWellStatus, input.getWellStatus())) { if (!CharSequenceUtil.equals(currentWellStatus, input.getWellStatus())) {
continue; continue;
} }
......
...@@ -178,7 +178,7 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer ...@@ -178,7 +178,7 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer
case BusinessConstant.ENV_CQ: case BusinessConstant.ENV_CQ:
String resultStr = ServiceUtil.doPostFormCq(context, String resultStr = ServiceUtil.doPostFormCq(context,
ThirdPartyApiConstant.CQ_WELL_STATION_PV_DATA, ThirdPartyApiConstant.CQ_WELL_STATION_PV_DATA,
new HashMap<>(0)); Collections.emptyMap());
context.getLogger().info("*** CQ_WELL_STATION_PV_DATA : {}", resultStr); context.getLogger().info("*** CQ_WELL_STATION_PV_DATA : {}", resultStr);
outputs = JSON.parseArray(resultStr, GetThirdActivePowerViewOutput.class); outputs = JSON.parseArray(resultStr, GetThirdActivePowerViewOutput.class);
break; break;
...@@ -287,7 +287,7 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer ...@@ -287,7 +287,7 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer
case BusinessConstant.ENV_CQ: case BusinessConstant.ENV_CQ:
String resultStr = ServiceUtil.doPostFormCq(context, String resultStr = ServiceUtil.doPostFormCq(context,
ThirdPartyApiConstant.CQ_WELL_REAL_PV_DATA, ThirdPartyApiConstant.CQ_WELL_REAL_PV_DATA,
new HashMap<>(0)); Collections.emptyMap());
context.getLogger().info("*** CQ_WELL_REAL_PV_DATA : {}", resultStr); context.getLogger().info("*** CQ_WELL_REAL_PV_DATA : {}", resultStr);
outputs = JSON.parseArray(resultStr, GetThirdCurrentWellConditionViewOutput.class); outputs = JSON.parseArray(resultStr, GetThirdCurrentWellConditionViewOutput.class);
break; break;
...@@ -302,7 +302,7 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer ...@@ -302,7 +302,7 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer
BigDecimal cumulativeProduction; BigDecimal cumulativeProduction;
List<ThirdCurrentWellConditionView> dtoList = new ArrayList<>(outputs.size()); List<ThirdCurrentWellConditionView> dtoList = new ArrayList<>(outputs.size());
for (GetThirdCurrentWellConditionViewOutput o : outputs) { for (GetThirdCurrentWellConditionViewOutput o : outputs) {
cumulativeProduction = Optional.ofNullable(o.getCumulativeProduction()).orElse(BigDecimal.ZERO); cumulativeProduction = ObjectUtil.defaultIfNull(o.getCumulativeProduction(), BigDecimal.ZERO);
cumulativeProduction = cumulativeProduction.compareTo(BigDecimal.ZERO) < 0 ? BigDecimal.ZERO : cumulativeProduction; cumulativeProduction = cumulativeProduction.compareTo(BigDecimal.ZERO) < 0 ? BigDecimal.ZERO : cumulativeProduction;
dtoList.add( dtoList.add(
ThirdCurrentWellConditionView.builder() ThirdCurrentWellConditionView.builder()
...@@ -310,7 +310,7 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer ...@@ -310,7 +310,7 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer
.systemSource(oilFieldCode) .systemSource(oilFieldCode)
.wellNumber(o.getWellNumber()) .wellNumber(o.getWellNumber())
.nextTime(o.getNextTime()) .nextTime(o.getNextTime())
.wellStatus(Optional.ofNullable(o.getWellStatus()).orElse("停井")) .wellStatus(ObjectUtil.defaultIfNull(o.getWellStatus(), BusinessConstant.CLOSE_WELL))
.cumulativeProduction(cumulativeProduction) .cumulativeProduction(cumulativeProduction)
.runningTime(o.getRunningTime()) .runningTime(o.getRunningTime())
.updateTime(date) .updateTime(date)
...@@ -516,7 +516,7 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer ...@@ -516,7 +516,7 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer
case BusinessConstant.ENV_CQ: case BusinessConstant.ENV_CQ:
String resultStr = ServiceUtil.doPostFormCq(context, String resultStr = ServiceUtil.doPostFormCq(context,
ThirdPartyApiConstant.CQ_GROUP_REAL_PV_DATA, ThirdPartyApiConstant.CQ_GROUP_REAL_PV_DATA,
new HashMap<>(0)); Collections.emptyMap());
context.getLogger().info("*** CQ_GROUP_REAL_PV_DATA : {}", resultStr); context.getLogger().info("*** CQ_GROUP_REAL_PV_DATA : {}", resultStr);
outputs = JSON.parseArray(resultStr, GetCumulativePowerGenerationOutput.class); outputs = JSON.parseArray(resultStr, GetCumulativePowerGenerationOutput.class);
break; break;
...@@ -657,7 +657,7 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer ...@@ -657,7 +657,7 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer
case BusinessConstant.ENV_CQ: case BusinessConstant.ENV_CQ:
String resultStr = ServiceUtil.doPostFormCq(context, String resultStr = ServiceUtil.doPostFormCq(context,
ThirdPartyApiConstant.CQ_AVG_ACTIVE_POWER, ThirdPartyApiConstant.CQ_AVG_ACTIVE_POWER,
new HashMap<>(0)); Collections.emptyMap());
context.getLogger().info("*** CQ_AVG_ACTIVE_POWER : {}", resultStr); context.getLogger().info("*** CQ_AVG_ACTIVE_POWER : {}", resultStr);
outputs = JSON.parseArray(resultStr, GetThirdWellAvgActivePowerOutput.class); outputs = JSON.parseArray(resultStr, GetThirdWellAvgActivePowerOutput.class);
break; break;
......
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