diff --git a/jeecg-boot-base-core/src/main/java/org/jeecg/common/constant/SymbolConstant.java b/jeecg-boot-base-core/src/main/java/org/jeecg/common/constant/SymbolConstant.java index 998e865b..3978517a 100644 --- a/jeecg-boot-base-core/src/main/java/org/jeecg/common/constant/SymbolConstant.java +++ b/jeecg-boot-base-core/src/main/java/org/jeecg/common/constant/SymbolConstant.java @@ -126,4 +126,8 @@ public class SymbolConstant { public static final String LINE = "\n"; public static final String AT = "@"; + + public static final String VERTICAL = "|"; + + public static final char VERTICAL_CHAR = '|'; } \ No newline at end of file diff --git a/jeecg-module-station-operation/src/main/java/org/jeecg/modules/mapper/CalCulStationInfoPgMapper.java b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/mapper/CalCulStationInfoPgMapper.java new file mode 100644 index 00000000..b2e1bda3 --- /dev/null +++ b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/mapper/CalCulStationInfoPgMapper.java @@ -0,0 +1,84 @@ +package org.jeecg.modules.mapper; + +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; +import org.jeecg.modules.entity.data.ProvisionData; +import org.jeecg.modules.entity.data.StationInfo; + +import java.util.List; +@Mapper +public interface CalCulStationInfoPgMapper { + + StationInfo getStationInfo(@Param("stationCode") String stationCode); + + ProvisionData findPhdfProvisionRateSauna(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("number") String number, @Param("stationId") String stationId); + + ProvisionData findPhdfProvisionEfficiencySauna(@Param("liveLow") String liveLow,@Param("liveHigh") String liveHigh,@Param("quantity") String quantity,@Param("mdc") String mdc,@Param("collectLow") String collectLow,@Param("collectHigh") String collectHigh,@Param("xeVolume") String xeVolume,@Param("nuclideName") String nuclideName,@Param("liveQc") String liveQc,@Param("curDateTime") String curDateTime,@Param("pretime") String pretime,@Param("number") String number,@Param("stationId") String stationId); + + ProvisionData findPhdProvisionRateSauna(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("number") String number, @Param("stationId") String stationId); + + ProvisionData findPhdProvisionEfficiencySauna(@Param("liveLow") String liveLow,@Param("liveHigh") String liveHigh,@Param("quantity") String quantity,@Param("mdc") String mdc,@Param("collectLow") String collectLow,@Param("collectHigh") String collectHigh,@Param("xeVolume") String xeVolume,@Param("nuclideName") String nuclideName,@Param("liveQc") String liveQc,@Param("curDateTime") String curDateTime,@Param("pretime") String pretime,@Param("number") String number,@Param("stationId") String stationId); + + ProvisionData findMetProvisionSauna(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("met") String met, @Param("stationId") String stationId); + + ProvisionData findSohProvisionSauna(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("soh") String soh, @Param("stationId") String stationId); + + ProvisionData findSphdProvisionSauna(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("stationId") String stationId); + + ProvisionData findSphdMetProvisionSauna(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("stationId") String stationId); + + ProvisionData findSphdMetSohProvisionSauna(@Param("SPHD_NUM") String SPHD_NUM, @Param("MET_NUM") String MET_NUM, @Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("sphdMetSoh") String sphdMetSoh, @Param("stationId") String stationId); + + ProvisionData findPhdfProvisionRateSpalax(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("number") String number, @Param("stationId") String stationId); + + ProvisionData findPhdfProvisionEfficiencySpalax(@Param("liveLow") String liveLow,@Param("liveHigh") String liveHigh,@Param("quantity") String quantity, @Param("collectLow") String collectLow,@Param("collectHigh") String collectHigh, @Param("liveQc") String liveQc,@Param("curDateTime") String curDateTime,@Param("pretime") String pretime,@Param("number") String number,@Param("stationId") String stationId); + + ProvisionData findPhdProvisionRateSpalax(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("number") String number, @Param("stationId") String stationId); + + ProvisionData findPhdProvisionEfficiencySpalax(@Param("liveLow") String liveLow,@Param("liveHigh") String liveHigh,@Param("quantity") String quantity, @Param("collectLow") String collectLow,@Param("collectHigh") String collectHigh, @Param("liveQc") String liveQc,@Param("curDateTime") String curDateTime,@Param("pretime") String pretime,@Param("number") String number,@Param("stationId") String stationId); + + ProvisionData findMetProvisionSpalax(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("met") String met, @Param("stationId") String stationId); + + ProvisionData findSohProvisionSpalax(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("soh") String soh, @Param("stationId") String stationId); + + ProvisionData findSphdProvisionSpalax(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("stationId") String stationId); + + ProvisionData findSphdMetProvisionSpalax(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("stationId") String stationId); + + ProvisionData findSphdMetSohProvisionSpalax(@Param("SPHD_NUM") String SPHD_NUM, @Param("MET_NUM") String MET_NUM, @Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("sphdMetSoh") String sphdMetSoh, @Param("stationId") String stationId); + + ProvisionData findPhdfProvisionRateParticulate(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("number") String number, @Param("stationId") String stationId); + + ProvisionData findPhdfProvisionEfficiencyParticulate(@Param("liveLow") String liveLow,@Param("liveHigh") String liveHigh,@Param("quantity") String quantity, @Param("collectLow") String collectLow,@Param("collectHigh") String collectHigh, @Param("curDateTime") String curDateTime,@Param("pretime") String pretime,@Param("number") String number,@Param("stationId") String stationId); + + ProvisionData findPhdProvisionRateParticulate(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("number") String number, @Param("stationId") String stationId); + + ProvisionData findPhdProvisionEfficiencyParticulate(@Param("liveLow") String liveLow,@Param("liveHigh") String liveHigh,@Param("quantity") String quantity, @Param("collectLow") String collectLow,@Param("collectHigh") String collectHigh, @Param("curDateTime") String curDateTime,@Param("pretime") String pretime,@Param("number") String number,@Param("stationId") String stationId); + + ProvisionData findMetProvisionParticulate(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("met") String met, @Param("stationId") String stationId); + + ProvisionData findSohProvisionParticulate(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("soh") String soh, @Param("stationId") String stationId); + + ProvisionData findSphdProvisionParticulate(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("stationId") String stationId); + + ProvisionData findSphdMetProvisionParticulate(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("stationId") String stationId); + + ProvisionData findSphdMetSohProvisionParticulate(@Param("SPHD_NUM") String SPHD_NUM, @Param("MET_NUM") String MET_NUM, @Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("sphdMetSoh") String sphdMetSoh, @Param("stationId") String stationId); + + List getUsed(Integer stationId); + + //region 新加计算台站类型数据提供率 + ProvisionData findPhdfProvisionRateSauna2(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("number") String number, @Param("stationId") String stationId); + ProvisionData findPhdProvisionRateSauna2(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("number") String number, @Param("stationId") String stationId); + ProvisionData findPhdProvisionEfficiencySauna2(@Param("liveLow") String liveLow,@Param("liveHigh") String liveHigh,@Param("quantity") String quantity,@Param("mdc") String mdc,@Param("collectLow") String collectLow,@Param("collectHigh") String collectHigh,@Param("xeVolume") String xeVolume,@Param("nuclideName") String nuclideName,@Param("liveQc") String liveQc,@Param("curDateTime") String curDateTime,@Param("pretime") String pretime,@Param("number") String number,@Param("stationId") String stationId); + + ProvisionData findSphdProvisionSauna2(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("stationId") String stationId); + + ProvisionData findPhdfProvisionEfficiencySpalaxPLC(@Param("liveLow") String liveLow,@Param("liveHigh") String liveHigh,@Param("quantity") String quantity, @Param("collectLow") String collectLow,@Param("collectHigh") String collectHigh, @Param("liveQc") String liveQc,@Param("curDateTime") String curDateTime,@Param("pretime") String pretime,@Param("number") String number,@Param("stationId") String stationId); + + ProvisionData findPhdProvisionRateSpalaxPLC(@Param("curDateTime") String curDateTime, @Param("pretime") String pretime, @Param("number") String number, @Param("stationId") String stationId); + + ProvisionData findPhdProvisionEfficiencySpalaxPLC(@Param("liveLow") String liveLow,@Param("liveHigh") String liveHigh,@Param("quantity") String quantity, @Param("collectLow") String collectLow,@Param("collectHigh") String collectHigh, @Param("liveQc") String liveQc,@Param("curDateTime") String curDateTime,@Param("pretime") String pretime,@Param("number") String number,@Param("stationId") String stationId); + //endregion + +} diff --git a/jeecg-module-station-operation/src/main/java/org/jeecg/modules/mapper/xml/calCulStationInfoMapper.xml b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/mapper/xml/calCulStationInfoMapper.xml index b3f4c43b..b7645eb9 100644 --- a/jeecg-module-station-operation/src/main/java/org/jeecg/modules/mapper/xml/calCulStationInfoMapper.xml +++ b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/mapper/xml/calCulStationInfoMapper.xml @@ -519,5 +519,4 @@ - \ No newline at end of file diff --git a/jeecg-module-station-operation/src/main/java/org/jeecg/modules/mapper/xml/calCulStationInfoPgMapper.xml b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/mapper/xml/calCulStationInfoPgMapper.xml new file mode 100644 index 00000000..92a1cfa8 --- /dev/null +++ b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/mapper/xml/calCulStationInfoPgMapper.xml @@ -0,0 +1,522 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/CalCulStationInfoServiceImpl.java b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/CalCulStationInfoServiceImpl.java index 82a10f23..cb55ea08 100644 --- a/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/CalCulStationInfoServiceImpl.java +++ b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/CalCulStationInfoServiceImpl.java @@ -1,16 +1,22 @@ package org.jeecg.modules.service.impl; +import com.baomidou.dynamic.datasource.DynamicRoutingDataSource; import com.baomidou.dynamic.datasource.annotation.DS; +import com.baomidou.mybatisplus.annotation.DbType; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import org.jeecg.modules.entity.data.ProvisionData; import org.jeecg.modules.entity.data.StationInfo; import org.jeecg.modules.mapper.CalCulStationInfoMapper; +import org.jeecg.modules.mapper.CalCulStationInfoPgMapper; import org.jeecg.modules.service.ICalCulStationDataService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; +import javax.annotation.PostConstruct; +import javax.sql.DataSource; +import java.sql.SQLException; import java.util.List; import java.util.Objects; @@ -20,6 +26,20 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { @Autowired private CalCulStationInfoMapper calCulStationInfoMapper; + @Autowired + private CalCulStationInfoPgMapper calCulStationInfoPgMapper; + @Autowired + private DataSource dataSource; + private DbType databaseType; + + @PostConstruct + public void initDbType() throws SQLException { + DynamicRoutingDataSource ds = (DynamicRoutingDataSource) dataSource; + String databaseProductName = ds.getDataSource("ora").getConnection().getMetaData().getDatabaseProductName(); + databaseType = DbType.getDbType(databaseProductName); + + } + @Override public StationInfo getStationInfo(String stationCode) { @@ -38,7 +58,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findPhdfProvisionRateSauna(String curDateTime, String pretime, String number, String stationId) { - ProvisionData provisionRate = calCulStationInfoMapper.findPhdfProvisionRateSauna(curDateTime, pretime, number, stationId); + ProvisionData provisionRate = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + provisionRate = calCulStationInfoPgMapper.findPhdfProvisionRateSauna(curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + provisionRate = calCulStationInfoMapper.findPhdfProvisionRateSauna(curDateTime, pretime, number, stationId); + } return provisionRate; } @@ -62,7 +87,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findPhdfProvisionEfficiencySauna(String liveLow, String liveHigh, String quantity, String mdc, String collectLow, String collectHigh, String xeVolume, String nuclideName, String liveQc, String curDateTime, String pretime, String number, String stationId) { - ProvisionData provisionEfficiency = calCulStationInfoMapper.findPhdfProvisionEfficiencySauna(liveLow, liveHigh, quantity, mdc, collectLow, collectHigh, xeVolume, nuclideName, liveQc, curDateTime, pretime, number, stationId); + ProvisionData provisionEfficiency = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + provisionEfficiency = calCulStationInfoPgMapper.findPhdfProvisionEfficiencySauna(liveLow, liveHigh, quantity, mdc, collectLow, collectHigh, xeVolume, nuclideName, liveQc, curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + provisionEfficiency = calCulStationInfoMapper.findPhdfProvisionEfficiencySauna(liveLow, liveHigh, quantity, mdc, collectLow, collectHigh, xeVolume, nuclideName, liveQc, curDateTime, pretime, number, stationId); + } return provisionEfficiency; } @@ -77,7 +107,13 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findPhdProvisionRateSauna(String curDateTime, String pretime, String number, String stationId) { - ProvisionData provisionRate = calCulStationInfoMapper.findPhdProvisionRateSauna(curDateTime, pretime, number, stationId); + + ProvisionData provisionRate = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + provisionRate = calCulStationInfoPgMapper.findPhdProvisionRateSauna(curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + provisionRate = calCulStationInfoMapper.findPhdProvisionRateSauna(curDateTime, pretime, number, stationId); + } return provisionRate; } @@ -101,7 +137,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findPhdProvisionEfficiencySauna(String liveLow, String liveHigh, String quantity, String mdc, String collectLow, String collectHigh, String xeVolume, String nuclideName, String liveQc, String curDateTime, String pretime, String number, String stationId) { - ProvisionData provisionEfficiency = calCulStationInfoMapper.findPhdProvisionEfficiencySauna(liveLow, liveHigh, quantity, mdc, collectLow, collectHigh, xeVolume, nuclideName, liveQc, curDateTime, pretime, number, stationId); + ProvisionData provisionEfficiency = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + provisionEfficiency = calCulStationInfoPgMapper.findPhdProvisionEfficiencySauna(liveLow, liveHigh, quantity, mdc, collectLow, collectHigh, xeVolume, nuclideName, liveQc, curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + provisionEfficiency = calCulStationInfoMapper.findPhdProvisionEfficiencySauna(liveLow, liveHigh, quantity, mdc, collectLow, collectHigh, xeVolume, nuclideName, liveQc, curDateTime, pretime, number, stationId); + } return provisionEfficiency; } @@ -117,7 +158,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findMetProvisionSauna(String curDateTime, String pretime, String met, String stationId) { - ProvisionData metProvision = calCulStationInfoMapper.findMetProvisionSauna(curDateTime, pretime, met, stationId); + ProvisionData metProvision = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + metProvision = calCulStationInfoPgMapper.findMetProvisionSauna(curDateTime, pretime, met, stationId); + } else if (databaseType== DbType.ORACLE) { + metProvision = calCulStationInfoMapper.findMetProvisionSauna(curDateTime, pretime, met, stationId); + } return metProvision; } @@ -132,7 +178,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findSohProvisionSauna(String curDateTime, String pretime, String soh, String stationId) { - ProvisionData sohProvision = calCulStationInfoMapper.findSohProvisionSauna(curDateTime, pretime, soh, stationId); + ProvisionData sohProvision = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + sohProvision = calCulStationInfoPgMapper.findSohProvisionSauna(curDateTime, pretime, soh, stationId); + } else if (databaseType== DbType.ORACLE) { + sohProvision = calCulStationInfoMapper.findSohProvisionSauna(curDateTime, pretime, soh, stationId); + } return sohProvision; } @@ -146,7 +197,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findSphdProvisionSauna(String curDateTime, String pretime, String stationId) { - ProvisionData sphdProvision = calCulStationInfoMapper.findSphdProvisionSauna(curDateTime, pretime, stationId); + ProvisionData sphdProvision = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + sphdProvision = calCulStationInfoPgMapper.findSphdProvisionSauna(curDateTime, pretime, stationId); + } else if (databaseType== DbType.ORACLE) { + sphdProvision = calCulStationInfoMapper.findSphdProvisionSauna(curDateTime, pretime, stationId); + } return sphdProvision; } @@ -160,7 +216,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findSphdMetProvisionSauna(String curDateTime, String pretime, String stationId) { - ProvisionData sphdMetProvision = calCulStationInfoMapper.findSphdMetProvisionSauna(curDateTime, pretime, stationId); + ProvisionData sphdMetProvision = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + sphdMetProvision = calCulStationInfoPgMapper.findSphdMetProvisionSauna(curDateTime, pretime, stationId); + } else if (databaseType== DbType.ORACLE) { + sphdMetProvision = calCulStationInfoMapper.findSphdMetProvisionSauna(curDateTime, pretime, stationId); + } return sphdMetProvision; } @@ -177,7 +238,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findSphdMetSohProvisionSauna(String SPHD_NUM, String MET_NUM, String curDateTime, String pretime, String sphdMetSoh, String stationId) { - ProvisionData sphdMetSohProvision = calCulStationInfoMapper.findSphdMetSohProvisionSauna(SPHD_NUM, MET_NUM, curDateTime, pretime, sphdMetSoh, stationId); + ProvisionData sphdMetSohProvision = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + sphdMetSohProvision = calCulStationInfoPgMapper.findSphdMetSohProvisionSauna(SPHD_NUM, MET_NUM, curDateTime, pretime, sphdMetSoh, stationId); + } else if (databaseType== DbType.ORACLE) { + sphdMetSohProvision = calCulStationInfoMapper.findSphdMetSohProvisionSauna(SPHD_NUM, MET_NUM, curDateTime, pretime, sphdMetSoh, stationId); + } return sphdMetSohProvision; } @@ -192,7 +258,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findPhdfProvisionRateSpalax(String curDateTime, String pretime, String number, String stationId) { - ProvisionData phdfProvisionRate = calCulStationInfoMapper.findPhdfProvisionRateSpalax(curDateTime, pretime, number, stationId); + ProvisionData phdfProvisionRate = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + phdfProvisionRate = calCulStationInfoPgMapper.findPhdfProvisionRateSpalax(curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + phdfProvisionRate = calCulStationInfoMapper.findPhdfProvisionRateSpalax(curDateTime, pretime, number, stationId); + } return phdfProvisionRate; } @@ -213,7 +284,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findPhdfProvisionEfficiencySpalax(String liveLow, String liveHigh, String quantity, String collectLow, String collectHigh, String liveQc, String curDateTime, String pretime, String number, String stationId) { - ProvisionData phdfProvisionEfficiency = calCulStationInfoMapper.findPhdfProvisionEfficiencySpalax(liveLow, liveHigh, quantity, collectLow, collectHigh, liveQc, curDateTime, pretime, number, stationId); + ProvisionData phdfProvisionEfficiency = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + phdfProvisionEfficiency = calCulStationInfoPgMapper.findPhdfProvisionEfficiencySpalax(liveLow, liveHigh, quantity, collectLow, collectHigh, liveQc, curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + phdfProvisionEfficiency = calCulStationInfoMapper.findPhdfProvisionEfficiencySpalax(liveLow, liveHigh, quantity, collectLow, collectHigh, liveQc, curDateTime, pretime, number, stationId); + } return phdfProvisionEfficiency; } @@ -228,7 +304,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findPhdProvisionRateSpalax(String curDateTime, String pretime, String number, String stationId) { - ProvisionData phdProvisionRate = calCulStationInfoMapper.findPhdProvisionRateSpalax(curDateTime, pretime, number, stationId); + ProvisionData phdProvisionRate = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + phdProvisionRate = calCulStationInfoPgMapper.findPhdProvisionRateSpalax(curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + phdProvisionRate = calCulStationInfoMapper.findPhdProvisionRateSpalax(curDateTime, pretime, number, stationId); + } return phdProvisionRate; } @@ -249,7 +330,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findPhdProvisionEfficiencySpalax(String liveLow, String liveHigh, String quantity, String collectLow, String collectHigh, String liveQc, String curDateTime, String pretime, String number, String stationId) { - ProvisionData phdProvisionEfficiency = calCulStationInfoMapper.findPhdProvisionEfficiencySpalax(liveLow, liveHigh, quantity, collectLow, collectHigh, liveQc, curDateTime, pretime, number, stationId); + ProvisionData phdProvisionEfficiency = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + phdProvisionEfficiency = calCulStationInfoPgMapper.findPhdProvisionEfficiencySpalax(liveLow, liveHigh, quantity, collectLow, collectHigh, liveQc, curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + phdProvisionEfficiency = calCulStationInfoMapper.findPhdProvisionEfficiencySpalax(liveLow, liveHigh, quantity, collectLow, collectHigh, liveQc, curDateTime, pretime, number, stationId); + } return phdProvisionEfficiency; } @@ -264,7 +350,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findMetProvisionSpalax(String curDateTime, String pretime, String met, String stationId) { - ProvisionData metProvision = calCulStationInfoMapper.findMetProvisionSpalax(curDateTime, pretime, met, stationId); + ProvisionData metProvision = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + metProvision = calCulStationInfoPgMapper.findMetProvisionSpalax(curDateTime, pretime, met, stationId); + } else if (databaseType== DbType.ORACLE) { + metProvision = calCulStationInfoMapper.findMetProvisionSpalax(curDateTime, pretime, met, stationId); + } return metProvision; } @@ -279,7 +370,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findSohProvisionSpalax(String curDateTime, String pretime, String soh, String stationId) { - ProvisionData sohProvision = calCulStationInfoMapper.findSohProvisionSpalax(curDateTime, pretime, soh, stationId); + ProvisionData sohProvision = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + sohProvision = calCulStationInfoPgMapper.findSohProvisionSpalax(curDateTime, pretime, soh, stationId); + } else if (databaseType== DbType.ORACLE) { + sohProvision = calCulStationInfoMapper.findSohProvisionSpalax(curDateTime, pretime, soh, stationId); + } return sohProvision; } @@ -293,7 +389,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findSphdProvisionSpalax(String curDateTime, String pretime, String stationId) { - ProvisionData sphdProvision = calCulStationInfoMapper.findSphdProvisionSpalax(curDateTime, pretime, stationId); + ProvisionData sphdProvision = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + sphdProvision = calCulStationInfoPgMapper.findSphdProvisionSpalax(curDateTime, pretime, stationId); + } else if (databaseType== DbType.ORACLE) { + sphdProvision = calCulStationInfoMapper.findSphdProvisionSpalax(curDateTime, pretime, stationId); + } return sphdProvision; } @@ -307,7 +408,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findSphdMetProvisionSpalax(String curDateTime, String pretime, String stationId) { - ProvisionData sphdMetProvision = calCulStationInfoMapper.findSphdMetProvisionSpalax(curDateTime, pretime, stationId); + ProvisionData sphdMetProvision = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + sphdMetProvision = calCulStationInfoPgMapper.findSphdMetProvisionSpalax(curDateTime, pretime, stationId); + } else if (databaseType== DbType.ORACLE) { + sphdMetProvision = calCulStationInfoMapper.findSphdMetProvisionSpalax(curDateTime, pretime, stationId); + } return sphdMetProvision; } @@ -324,7 +430,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findSphdMetSohProvisionSpalax(String SPHD_NUM, String MET_NUM, String curDateTime, String pretime, String sphdMetSoh, String stationId) { - ProvisionData sphdMetSohProvision = calCulStationInfoMapper.findSphdMetSohProvisionSpalax(SPHD_NUM, MET_NUM, curDateTime, pretime, sphdMetSoh, stationId); + ProvisionData sphdMetSohProvision = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + sphdMetSohProvision = calCulStationInfoPgMapper.findSphdMetSohProvisionSpalax(SPHD_NUM, MET_NUM, curDateTime, pretime, sphdMetSoh, stationId); + } else if (databaseType== DbType.ORACLE) { + sphdMetSohProvision = calCulStationInfoMapper.findSphdMetSohProvisionSpalax(SPHD_NUM, MET_NUM, curDateTime, pretime, sphdMetSoh, stationId); + } return sphdMetSohProvision; } @@ -339,7 +450,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findPhdfProvisionRateParticulate(String curDateTime, String pretime, String number, String stationId) { - ProvisionData phdfProvisionRate = calCulStationInfoMapper.findPhdfProvisionRateParticulate(curDateTime, pretime, number, stationId); + ProvisionData phdfProvisionRate = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + phdfProvisionRate = calCulStationInfoPgMapper.findPhdfProvisionRateParticulate(curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + phdfProvisionRate = calCulStationInfoMapper.findPhdfProvisionRateParticulate(curDateTime, pretime, number, stationId); + } return phdfProvisionRate; } @@ -359,7 +475,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findPhdfProvisionEfficiencyParticulate(String liveLow, String liveHigh, String quantity, String collectLow, String collectHigh, String curDateTime, String pretime, String number, String stationId) { - ProvisionData phdfProvisionEfficiency = calCulStationInfoMapper.findPhdfProvisionEfficiencyParticulate(liveLow, liveHigh, quantity, collectLow, collectHigh, curDateTime, pretime, number, stationId); + ProvisionData phdfProvisionEfficiency = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + phdfProvisionEfficiency = calCulStationInfoPgMapper.findPhdfProvisionEfficiencyParticulate(liveLow, liveHigh, quantity, collectLow, collectHigh, curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + phdfProvisionEfficiency = calCulStationInfoMapper.findPhdfProvisionEfficiencyParticulate(liveLow, liveHigh, quantity, collectLow, collectHigh, curDateTime, pretime, number, stationId); + } return phdfProvisionEfficiency; } @@ -374,7 +495,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findPhdProvisionRateParticulate(String curDateTime, String pretime, String number, String stationId) { - ProvisionData phdProvisionRate = calCulStationInfoMapper.findPhdProvisionRateParticulate(curDateTime, pretime, number, stationId); + ProvisionData phdProvisionRate = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + phdProvisionRate = calCulStationInfoPgMapper.findPhdProvisionRateParticulate(curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + phdProvisionRate = calCulStationInfoMapper.findPhdProvisionRateParticulate(curDateTime, pretime, number, stationId); + } return phdProvisionRate; } @@ -394,7 +520,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findPhdProvisionEfficiencyParticulate(String liveLow, String liveHigh, String quantity, String collectLow, String collectHigh, String curDateTime, String pretime, String number, String stationId) { - ProvisionData phdProvisionEfficiency = calCulStationInfoMapper.findPhdProvisionEfficiencyParticulate(liveLow, liveHigh, quantity, collectLow, collectHigh, curDateTime, pretime, number, stationId); + ProvisionData phdProvisionEfficiency = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + phdProvisionEfficiency = calCulStationInfoPgMapper.findPhdProvisionEfficiencyParticulate(liveLow, liveHigh, quantity, collectLow, collectHigh, curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + phdProvisionEfficiency = calCulStationInfoMapper.findPhdProvisionEfficiencyParticulate(liveLow, liveHigh, quantity, collectLow, collectHigh, curDateTime, pretime, number, stationId); + } return phdProvisionEfficiency; } @@ -409,7 +540,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findMetProvisionParticulate(String curDateTime, String pretime, String met, String stationId) { - ProvisionData metProvision = calCulStationInfoMapper.findMetProvisionParticulate(curDateTime, pretime, met, stationId); + ProvisionData metProvision = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + metProvision = calCulStationInfoPgMapper.findMetProvisionParticulate(curDateTime, pretime, met, stationId); + } else if (databaseType== DbType.ORACLE) { + metProvision = calCulStationInfoMapper.findMetProvisionParticulate(curDateTime, pretime, met, stationId); + } return metProvision; } @@ -424,7 +560,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findSohProvisionParticulate(String curDateTime, String pretime, String soh, String stationId) { - ProvisionData sohProvision = calCulStationInfoMapper.findSohProvisionParticulate(curDateTime, pretime, soh, stationId); + ProvisionData sohProvision = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + sohProvision = calCulStationInfoPgMapper.findSohProvisionParticulate(curDateTime, pretime, soh, stationId); + } else if (databaseType== DbType.ORACLE) { + sohProvision = calCulStationInfoMapper.findSohProvisionParticulate(curDateTime, pretime, soh, stationId); + } return sohProvision; } @@ -438,7 +579,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findSphdProvisionParticulate(String curDateTime, String pretime, String stationId) { - ProvisionData sphdProvision = calCulStationInfoMapper.findSphdProvisionParticulate(curDateTime, pretime, stationId); + ProvisionData sphdProvision = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + sphdProvision = calCulStationInfoPgMapper.findSphdProvisionParticulate(curDateTime, pretime, stationId); + } else if (databaseType== DbType.ORACLE) { + sphdProvision = calCulStationInfoMapper.findSphdProvisionParticulate(curDateTime, pretime, stationId); + } return sphdProvision; } @@ -452,7 +598,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findSphdMetProvisionParticulate(String curDateTime, String pretime, String stationId) { - ProvisionData sphdMetProvision = calCulStationInfoMapper.findSphdMetProvisionParticulate(curDateTime, pretime, stationId); + ProvisionData sphdMetProvision = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + sphdMetProvision = calCulStationInfoPgMapper.findSphdMetProvisionParticulate(curDateTime, pretime, stationId); + } else if (databaseType== DbType.ORACLE) { + sphdMetProvision = calCulStationInfoMapper.findSphdMetProvisionParticulate(curDateTime, pretime, stationId); + } return sphdMetProvision; } @@ -469,7 +620,12 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { */ @Override public ProvisionData findSphdMetSohProvisionParticulate(String SPHD_NUM, String MET_NUM, String curDateTime, String pretime, String sphdMetSoh, String stationId) { - ProvisionData sphdMetSohProvision = calCulStationInfoMapper.findSphdMetSohProvisionParticulate(SPHD_NUM, MET_NUM, curDateTime, pretime, sphdMetSoh, stationId); + ProvisionData sphdMetSohProvision = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + sphdMetSohProvision = calCulStationInfoPgMapper.findSphdMetSohProvisionParticulate(SPHD_NUM, MET_NUM, curDateTime, pretime, sphdMetSoh, stationId); + } else if (databaseType== DbType.ORACLE) { + sphdMetSohProvision = calCulStationInfoMapper.findSphdMetSohProvisionParticulate(SPHD_NUM, MET_NUM, curDateTime, pretime, sphdMetSoh, stationId); + } return sphdMetSohProvision; } @@ -484,43 +640,82 @@ public class CalCulStationInfoServiceImpl implements ICalCulStationDataService { //region 新加计算台站类型数据提供率方法 @Override public ProvisionData findPhdfProvisionRateSauna2(String curDateTime, String pretime, String number, String stationId) { - ProvisionData provisionRate=calCulStationInfoMapper.findPhdfProvisionRateSauna2(curDateTime, pretime, number, stationId); + ProvisionData provisionRate = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + provisionRate = calCulStationInfoPgMapper.findPhdfProvisionRateSauna2(curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + provisionRate = calCulStationInfoMapper.findPhdfProvisionRateSauna2(curDateTime, pretime, number, stationId); + } return provisionRate; } @Override public ProvisionData findPhdProvisionRateSauna2(String curDateTime, String pretime, String number, String stationId) { - ProvisionData provisionRate = calCulStationInfoMapper.findPhdProvisionRateSauna2(curDateTime, pretime, number, stationId); + ProvisionData provisionRate = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + provisionRate = calCulStationInfoPgMapper.findPhdProvisionRateSauna2(curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + provisionRate = calCulStationInfoMapper.findPhdProvisionRateSauna2(curDateTime, pretime, number, stationId); + } return provisionRate; } @Override public ProvisionData findPhdProvisionEfficiencySauna2(String liveLow, String liveHigh, String quantity, String mdc, String collectLow, String collectHigh, String xeVolume, String nuclideName, String liveQc, String curDateTime, String pretime, String number, String stationId) { - ProvisionData provisionEfficiency=calCulStationInfoMapper.findPhdProvisionEfficiencySauna2(liveLow, liveHigh, quantity, mdc, collectLow, collectHigh, xeVolume, nuclideName, liveQc, curDateTime, pretime, number, stationId); + ProvisionData provisionEfficiency = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + provisionEfficiency = calCulStationInfoPgMapper.findPhdProvisionEfficiencySauna2(liveLow, liveHigh, quantity, mdc, collectLow, collectHigh, xeVolume, nuclideName, liveQc, curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + provisionEfficiency = calCulStationInfoMapper.findPhdProvisionEfficiencySauna2(liveLow, liveHigh, quantity, mdc, collectLow, collectHigh, xeVolume, nuclideName, liveQc, curDateTime, pretime, number, stationId); + } return provisionEfficiency; } @Override public ProvisionData findSphdProvisionSauna2(String curDateTime, String pretime, String stationId) { - ProvisionData sphdProvision = calCulStationInfoMapper.findSphdProvisionSauna2(curDateTime, pretime, stationId); + ProvisionData sphdProvision = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + sphdProvision = calCulStationInfoPgMapper.findSphdProvisionSauna2(curDateTime, pretime, stationId); + } else if (databaseType== DbType.ORACLE) { + sphdProvision = calCulStationInfoMapper.findSphdProvisionSauna2(curDateTime, pretime, stationId); + } return sphdProvision; } @Override public ProvisionData findPhdfProvisionEfficiencySpalaxPLC(String liveLow, String liveHigh, String quantity, String collectLow, String collectHigh, String liveQc, String curDateTime, String pretime, String number, String stationId) { - ProvisionData phdfProvisionEfficiency = calCulStationInfoMapper.findPhdfProvisionEfficiencySpalaxPLC(liveLow, liveHigh, quantity, collectLow, collectHigh, liveQc, curDateTime, pretime, number, stationId); + ProvisionData phdfProvisionEfficiency = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + phdfProvisionEfficiency = calCulStationInfoPgMapper.findPhdfProvisionEfficiencySpalaxPLC(liveLow, liveHigh, quantity, collectLow, collectHigh, liveQc, curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + phdfProvisionEfficiency = calCulStationInfoMapper.findPhdfProvisionEfficiencySpalaxPLC(liveLow, liveHigh, quantity, collectLow, collectHigh, liveQc, curDateTime, pretime, number, stationId); + } return phdfProvisionEfficiency; } @Override public ProvisionData findPhdProvisionRateSpalaxPLC(String curDateTime, String pretime, String number, String stationId) { - ProvisionData phdProvisionRate = calCulStationInfoMapper.findPhdProvisionRateSpalaxPLC(curDateTime, pretime, number, stationId); + ProvisionData phdProvisionRate = new ProvisionData(); + if (databaseType== DbType.POSTGRE_SQL) { + phdProvisionRate = calCulStationInfoPgMapper.findPhdProvisionRateSpalaxPLC(curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + phdProvisionRate = calCulStationInfoMapper.findPhdProvisionRateSpalaxPLC(curDateTime, pretime, number, stationId); + } return phdProvisionRate; } @Override public ProvisionData findPhdProvisionEfficiencySpalaxPLC(String liveLow, String liveHigh, String quantity, String collectLow, String collectHigh, String liveQc, String curDateTime, String pretime, String number, String stationId) { - ProvisionData phdProvisionEfficiency = calCulStationInfoMapper.findPhdProvisionEfficiencySpalaxPLC(liveLow, liveHigh, quantity, collectLow, collectHigh, liveQc, curDateTime, pretime, number, stationId); + ProvisionData phdProvisionEfficiency = new ProvisionData(); + try{ + if (databaseType== DbType.POSTGRE_SQL) { + phdProvisionEfficiency = calCulStationInfoPgMapper.findPhdProvisionEfficiencySpalaxPLC(liveLow, liveHigh, quantity, collectLow, collectHigh, liveQc, curDateTime, pretime, number, stationId); + } else if (databaseType== DbType.ORACLE) { + phdProvisionEfficiency = calCulStationInfoMapper.findPhdProvisionEfficiencySpalaxPLC(liveLow, liveHigh, quantity, collectLow, collectHigh, liveQc, curDateTime, pretime, number, stationId); + }} + catch(Exception e){ + System.out.println(e); + } return phdProvisionEfficiency; }