Skip to content

G
gf_back
Commit 8d95f85a authored by ZWT's avatar ZWT
Browse files
Options

得到的

parent b8bb9b0d
Show whitespace changes
Inline Side-by-side
Showing with 43 additions and 43 deletions
C12-prediction/pps-core-prediction/src/main/java/pps/core/prediction/service/EnergyConsumptionAnalysisService.java
View file @ 8d95f85a
......@@ -346,7 +346,7 @@ public class EnergyConsumptionAnalysisService {
"NVL( SUM( ELECTRICITY_CONSUMPTION_HH ), 0 ) AS ELECTRICITY_CONSUMPTION_HH",
"NVL( SUM( ELECTRICITY_CONSUMPTION_PH ), 0 ) AS ELECTRICITY_CONSUMPTION_PH",
yearFlag ? "TO_CHAR( DATA_DATE, 'YYYY-MM-' ) || '01 00:00:00' AS DATA_DATE" : "DATA_DATE")
.last(yearFlag ? "GROUP BY TO_CHAR( DATA_DATE, 'YYYY-MM-' )" : "GROUP BY data_date");
.last(yearFlag ? "GROUP BY TO_CHAR( DATA_DATE, 'YYYY-MM-' )" : "GROUP BY DATA_DATE");
} else {
queryWrapper.select("IFNULL( SUM( ELECTRICITY_CHARGE_CITY ), 0 ) AS ELECTRICITY_CHARGE_CITY",
"IFNULL( SUM( ELECTRICITY_CONSUMPTION_VH ), 0 ) AS ELECTRICITY_CONSUMPTION_VH",
......@@ -1230,15 +1230,15 @@ public class EnergyConsumptionAnalysisService {
if (CollUtil.isNotEmpty(plantList)) {
QueryWrapper<ThirdDailyAccumulationUpdateEnt> queryWrapper = new QueryWrapper<>();
if (CharSequenceUtil.equals(context.getProperty("x.db.databaseId"), BusinessConstant.ORACLE)) {
queryWrapper.select("NVL( SUM( photovoltaic_power ), 0 ) AS photovoltaic_power",
"NVL( SUM( daily_electricity_consumption ), 0 ) AS daily_electricity_consumption",
"NVL( SUM( daily_liquid_production ), 0 ) AS daily_liquid_production",
"NVL( SUM( in_place_consumption ), 0 ) AS in_place_consumption");
queryWrapper.select("NVL( SUM( PHOTOVOLTAIC_POWER ), 0 ) AS PHOTOVOLTAIC_POWER",
"NVL( SUM( DAILY_ELECTRICITY_CONSUMPTION ), 0 ) AS DAILY_ELECTRICITY_CONSUMPTION",
"NVL( SUM( DAILY_LIQUID_PRODUCTION ), 0 ) AS DAILY_LIQUID_PRODUCTION",
"NVL( SUM( IN_PLACE_CONSUMPTION ), 0 ) AS IN_PLACE_CONSUMPTION");
} else {
queryWrapper.select("IFNULL( SUM( photovoltaic_power ), 0 ) AS photovoltaic_power",
"IFNULL( SUM( daily_electricity_consumption ), 0 ) AS daily_electricity_consumption",
"IFNULL( SUM( daily_liquid_production ), 0 ) AS daily_liquid_production",
"IFNULL( SUM( in_place_consumption ), 0 ) AS in_place_consumption");
queryWrapper.select("IFNULL( SUM( PHOTOVOLTAIC_POWER ), 0 ) AS PHOTOVOLTAIC_POWER",
"IFNULL( SUM( DAILY_ELECTRICITY_CONSUMPTION ), 0 ) AS DAILY_ELECTRICITY_CONSUMPTION",
"IFNULL( SUM( DAILY_LIQUID_PRODUCTION ), 0 ) AS DAILY_LIQUID_PRODUCTION",
"IFNULL( SUM( IN_PLACE_CONSUMPTION ), 0 ) AS IN_PLACE_CONSUMPTION");
}
DateTime start = DateUtil.beginOfMonth(end);
//累计发电
......@@ -1710,16 +1710,16 @@ public class EnergyConsumptionAnalysisService {
StationDailyProductionSituationMapper situationMapper = context.getBean(StationDailyProductionSituationMapper.class);
QueryWrapper<StationDailyProductionSituationEnt> queryWrapper = new QueryWrapper<>();
if (CharSequenceUtil.equals(context.getProperty("x.db.databaseId"), BusinessConstant.ORACLE)) {
queryWrapper.select("NVL( ROUND( SUM( daily_electricity_consumption ), 2 ), 0 ) AS daily_electricity_consumption",
"NVL( ROUND( SUM( daily_liquid_production ), 2 ), 0 ) AS daily_liquid_production",
"NVL( ROUND( SUM( photovoltaic_power ), 2 ), 0 ) AS photovoltaic_power",
"data_date"
queryWrapper.select("NVL( ROUND( SUM( DAILY_ELECTRICITY_CONSUMPTION ), 2 ), 0 ) AS DAILY_ELECTRICITY_CONSUMPTION",
"NVL( ROUND( SUM( DAILY_LIQUID_PRODUCTION ), 2 ), 0 ) AS DAILY_LIQUID_PRODUCTION",
"NVL( ROUND( SUM( PHOTOVOLTAIC_POWER ), 2 ), 0 ) AS PHOTOVOLTAIC_POWER",
"DATA_DATE"
);
} else {
queryWrapper.select("IFNULL( ROUND( SUM( daily_electricity_consumption ), 2 ), 0 ) AS daily_electricity_consumption",
"IFNULL( ROUND( SUM( daily_liquid_production ), 2 ), 0 ) AS daily_liquid_production",
"IFNULL( ROUND( SUM( photovoltaic_power ), 2 ), 0 ) AS photovoltaic_power",
"data_date"
queryWrapper.select("IFNULL( ROUND( SUM( DAILY_ELECTRICITY_CONSUMPTION ), 2 ), 0 ) AS DAILY_ELECTRICITY_CONSUMPTION",
"IFNULL( ROUND( SUM( DAILY_LIQUID_PRODUCTION ), 2 ), 0 ) AS DAILY_LIQUID_PRODUCTION",
"IFNULL( ROUND( SUM( PHOTOVOLTAIC_POWER ), 2 ), 0 ) AS PHOTOVOLTAIC_POWER",
"DATA_DATE"
);
}
List<StationDailyProductionSituationEnt> list = situationMapper.selectList(queryWrapper.lambda()
......
C12-prediction/pps-core-prediction/src/main/java/pps/core/prediction/service/HomePageService.java
View file @ 8d95f85a
......@@ -457,7 +457,7 @@ public class HomePageService {
stationList = new ArrayList<>(4);
for (Map.Entry<String, List<DynamicQueryBasePowerLineOutput>> entry : listMap.entrySet()) {
EnergyConsumptionAnalysisEnt ent = mapper.selectOne(new QueryWrapper<EnergyConsumptionAnalysisEnt>()
.select(equals ? "NVL( SUM( power_consumption ), 0 ) AS power_consumption" : "IFNULL( SUM( power_consumption ), 0 ) AS power_consumption")
.select(equals ? "NVL( SUM( POWER_CONSUMPTION ), 0 ) AS POWER_CONSUMPTION" : "IFNULL( SUM( POWER_CONSUMPTION ), 0 ) AS POWER_CONSUMPTION")
.lambda()
.in(EnergyConsumptionAnalysisEnt::getStationName, entry.getValue().stream()
.map(DynamicQueryBasePowerLineOutput::getLineName)
......@@ -477,7 +477,7 @@ public class HomePageService {
.collect(Collectors.toList());
if (CollUtil.isNotEmpty(lineNameList)) {
List<EnergyConsumptionAnalysisEnt> list = mapper.selectList(new QueryWrapper<EnergyConsumptionAnalysisEnt>()
.select(equals ? "NVL( SUM( power_consumption ), 0 ) AS power_consumption" : "IFNULL( SUM( power_consumption ), 0 ) AS power_consumption", "station_name")
.select(equals ? "NVL( SUM( POWER_CONSUMPTION ), 0 ) AS POWER_CONSUMPTION" : "IFNULL( SUM( POWER_CONSUMPTION ), 0 ) AS POWER_CONSUMPTION", "STATION_NAME")
.lambda()
.in(EnergyConsumptionAnalysisEnt::getStationName, lineNameList)
.eq(EnergyConsumptionAnalysisEnt::getDataDate, startTime)
......@@ -622,17 +622,17 @@ public class HomePageService {
case BusinessConstant.ENV_CQ:
QueryWrapper<ThirdDailyAccumulationUpdateEnt> queryWrapper = new QueryWrapper<>();
if (CharSequenceUtil.equals(context.getProperty("x.db.databaseId"), BusinessConstant.ORACLE)) {
queryWrapper.select("NVL( SUM( photovoltaic_power ), 0 ) AS photovoltaic_power",
"NVL( SUM( daily_electricity_consumption ), 0 ) AS daily_electricity_consumption",
"NVL( SUM( daily_liquid_production ), 0 ) AS daily_liquid_production",
"NVL( SUM( energy_storage_discharge ), 0 ) AS energy_storage_discharge",
"NVL( SUM( in_place_consumption ), 0 ) AS in_place_consumption");
queryWrapper.select("NVL( SUM( PHOTOVOLTAIC_POWER ), 0 ) AS PHOTOVOLTAIC_POWER",
"NVL( SUM( DAILY_ELECTRICITY_CONSUMPTION ), 0 ) AS DAILY_ELECTRICITY_CONSUMPTION",
"NVL( SUM( DAILY_LIQUID_PRODUCTION ), 0 ) AS DAILY_LIQUID_PRODUCTION",
"NVL( SUM( ENERGY_STORAGE_DISCHARGE ), 0 ) AS ENERGY_STORAGE_DISCHARGE",
"NVL( SUM( IN_PLACE_CONSUMPTION ), 0 ) AS IN_PLACE_CONSUMPTION");
} else {
queryWrapper.select("IFNULL( SUM( photovoltaic_power ), 0 ) AS photovoltaic_power",
"IFNULL( SUM( daily_electricity_consumption ), 0 ) AS daily_electricity_consumption",
"IFNULL( SUM( daily_liquid_production ), 0 ) AS daily_liquid_production",
"IFNULL( SUM( energy_storage_discharge ), 0 ) AS energy_storage_discharge",
"IFNULL( SUM( in_place_consumption ), 0 ) AS in_place_consumption");
queryWrapper.select("IFNULL( SUM( PHOTOVOLTAIC_POWER ), 0 ) AS PHOTOVOLTAIC_POWER",
"IFNULL( SUM( DAILY_ELECTRICITY_CONSUMPTION ), 0 ) AS DAILY_ELECTRICITY_CONSUMPTION",
"IFNULL( SUM( DAILY_LIQUID_PRODUCTION ), 0 ) AS DAILY_LIQUID_PRODUCTION",
"IFNULL( SUM( ENERGY_STORAGE_DISCHARGE ), 0 ) AS ENERGY_STORAGE_DISCHARGE",
"IFNULL( SUM( IN_PLACE_CONSUMPTION ), 0 ) AS IN_PLACE_CONSUMPTION");
}
ThirdDailyAccumulationUpdateMapper analysisMapper = context.getBean(ThirdDailyAccumulationUpdateMapper.class);
......@@ -669,13 +669,13 @@ public class HomePageService {
case BusinessConstant.ENV_SY:
QueryWrapper<StationDailyProductionSituationEnt> wrapper = new QueryWrapper<>();
if (CharSequenceUtil.equals(context.getProperty("x.db.databaseId"), BusinessConstant.ORACLE)) {
wrapper.select("NVL( SUM( photovoltaic_power ), 0 ) AS photovoltaic_power",
"NVL( SUM( daily_electricity_consumption ), 0 ) AS daily_electricity_consumption",
"NVL( SUM( electricity_charge_city ), 0 ) AS electricity_charge_city");
wrapper.select("NVL( SUM( PHOTOVOLTAIC_POWER ), 0 ) AS PHOTOVOLTAIC_POWER",
"NVL( SUM( DAILY_ELECTRICITY_CONSUMPTION ), 0 ) AS DAILY_ELECTRICITY_CONSUMPTION",
"NVL( SUM( ELECTRICITY_CHARGE_CITY ), 0 ) AS ELECTRICITY_CHARGE_CITY");
} else {
wrapper.select("IFNULL( SUM( photovoltaic_power ), 0 ) AS photovoltaic_power",
"IFNULL( SUM( daily_electricity_consumption ), 0 ) AS daily_electricity_consumption",
"IFNULL( SUM( electricity_charge_city ), 0 ) AS electricity_charge_city");
wrapper.select("IFNULL( SUM( PHOTOVOLTAIC_POWER ), 0 ) AS PHOTOVOLTAIC_POWER",
"IFNULL( SUM( DAILY_ELECTRICITY_CONSUMPTION ), 0 ) AS DAILY_ELECTRICITY_CONSUMPTION",
"IFNULL( SUM( ELECTRICITY_CHARGE_CITY ), 0 ) AS ELECTRICITY_CHARGE_CITY");
}
StationDailyProductionSituationMapper dailyMapper = context.getBean(StationDailyProductionSituationMapper.class);
StationDailyProductionSituationEnt dailyEnt = dailyMapper.selectOne(wrapper.lambda()
......@@ -851,16 +851,16 @@ public class HomePageService {
DateTime today = DateUtil.beginOfDay(DateUtil.date());
ThirdDailyAccumulationUpdateMapper mapper = context.getBean(ThirdDailyAccumulationUpdateMapper.class);
dailyAccumulation = mapper.selectOne(new QueryWrapper<ThirdDailyAccumulationUpdateEnt>()
.select("IFNULL( AVG( photovoltaic_power ), 0 ) AS photovoltaic_power",
"IFNULL( AVG( daily_electricity_consumption ), 0 ) AS daily_electricity_consumption",
"IFNULL( AVG( daily_liquid_production ), 0 ) AS daily_liquid_production",
"IFNULL( AVG( in_place_consumption ), 0 ) AS in_place_consumption")
.select("IFNULL( AVG( PHOTOVOLTAIC_POWER ), 0 ) AS PHOTOVOLTAIC_POWER",
"IFNULL( AVG( DAILY_ELECTRICITY_CONSUMPTION ), 0 ) AS DAILY_ELECTRICITY_CONSUMPTION",
"IFNULL( AVG( DAILY_LIQUID_PRODUCTION ), 0 ) AS DAILY_LIQUID_PRODUCTION",
"IFNULL( AVG( IN_PLACE_CONSUMPTION ), 0 ) AS IN_PLACE_CONSUMPTION")
.lambda()
.in(ThirdDailyAccumulationUpdateEnt::getStationName, plantViewList.stream()
.map(DynamicQueryBasePowerLinePlantViewOutput::getStationName)
.collect(Collectors.toList()))
.eq(ThirdDailyAccumulationUpdateEnt::getSystemSource, oilFieldCode)
.apply("DATE( create_date ) = {0}", today)
.apply("DATE( CREATE_DATE ) = {0}", today)
.groupBy(ThirdDailyAccumulationUpdateEnt::getStationName)
);
break;
......
C12-prediction/pps-core-prediction/src/main/java/pps/core/prediction/service/PlantPredictedPowerDataService.java
View file @ 8d95f85a
......@@ -86,7 +86,7 @@ public class PlantPredictedPowerDataService {
PlantPredictedPowerDataMapper mapper = context.getBean(PlantPredictedPowerDataMapper.class);
Date date = new Date();
QueryWrapper<PlantPredictedPowerDataEnt> queryWrapper = new QueryWrapper<>();
queryWrapper.select("IFNULL(avg(power ) , 0 ) power")
queryWrapper.select("IFNULL(AVG(POWER ) , 0 ) POWER")
.lambda()
.eq(PlantPredictedPowerDataEnt::getPlantId, input.getPlantId())
.ge(PlantPredictedPowerDataEnt::getDataDate, date)
......@@ -94,7 +94,7 @@ public class PlantPredictedPowerDataService {
PlantPredictedPowerDataEnt currentData = mapper.selectOne(queryWrapper);
queryWrapper.clear();
DateTime lastYear = DateUtil.offset(date, DateField.YEAR, -1);
queryWrapper.select("IFNULL(avg(power ) , 0 ) power")
queryWrapper.select("IFNULL(AVG(POWER ) , 0 ) POWER")
.lambda()
.eq(PlantPredictedPowerDataEnt::getPlantId, input.getPlantId())
.ge(PlantPredictedPowerDataEnt::getDataDate, lastYear)
......@@ -105,7 +105,7 @@ public class PlantPredictedPowerDataService {
compare = currentData.getPower().divide(lastData.getPower(), 6, BigDecimal.ROUND_HALF_UP);
}
queryWrapper.clear();
queryWrapper.select("data_date, power")
queryWrapper.select("DATA_DATE, POWER")
.lambda()
.eq(PlantPredictedPowerDataEnt::getPlantId, input.getPlantId())
.ge(PlantPredictedPowerDataEnt::getDataDate, lastYear)
......
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