diff --git a/backend/src/main/java/com/yfd/platform/env/wt/service/impl/SdWtMonitorServiceImpl.java b/backend/src/main/java/com/yfd/platform/env/wt/service/impl/SdWtMonitorServiceImpl.java index c4d43c1..324e338 100644 --- a/backend/src/main/java/com/yfd/platform/env/wt/service/impl/SdWtMonitorServiceImpl.java +++ b/backend/src/main/java/com/yfd/platform/env/wt/service/impl/SdWtMonitorServiceImpl.java @@ -500,6 +500,7 @@ public class SdWtMonitorServiceImpl implements SdWtMonitorService { DataSourceLoadOptionsBase loadOptions = dataSourceRequest.toDevRequest(); String mway = QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "mway"); String sttpCode = QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "sttpCode"); + String stcd = QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "stcd"); String rstcd = QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "rstcd"); String stnm = QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "stnm"); String coenvwState = QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "coenvwState"); @@ -575,6 +576,14 @@ public class SdWtMonitorServiceImpl implements SdWtMonitorService { sql.append("AND wt.RSTCD = #{map.rstcd} "); } } + if (stcd != null && !stcd.isBlank()) { + paramMap.put("stcd", stcd); + if (queryEngDirectly) { + sql.append("AND eng.STCD = #{map.stcd} "); + } else { + sql.append("AND wt.STCD = #{map.stcd} "); + } + } if (stnm != null && !stnm.isBlank()) { paramMap.put("stnm", "%" + stnm + "%"); if (queryEngDirectly) {