diff --git a/backend/src/main/java/com/yfd/platform/qgc_env/fb/controller/FbStationController.java b/backend/src/main/java/com/yfd/platform/qgc_env/fb/controller/FbStationController.java index 7fa6c42f..5b7c3eee 100644 --- a/backend/src/main/java/com/yfd/platform/qgc_env/fb/controller/FbStationController.java +++ b/backend/src/main/java/com/yfd/platform/qgc_env/fb/controller/FbStationController.java @@ -146,4 +146,10 @@ public class FbStationController { public ResponseResult getFishbreedrFishKendoListCust(@RequestBody DataSourceRequest dataSourceRequest) { return ResponseResult.successData(fbStationService.getFishbreedrFishKendoListCust(dataSourceRequest)); } + + @PostMapping("/point/GetKendoListCust") + @Operation(summary = "增殖站地图描点") + public ResponseResult getFbPointKendoListCust(@RequestBody DataSourceRequest dataSourceRequest) { + return ResponseResult.successData(fbStationService.getFbPointKendoListCust(dataSourceRequest)); + } } diff --git a/backend/src/main/java/com/yfd/platform/qgc_env/fb/entity/vo/FbTracingPointVo.java b/backend/src/main/java/com/yfd/platform/qgc_env/fb/entity/vo/FbTracingPointVo.java new file mode 100644 index 00000000..eb17b855 --- /dev/null +++ b/backend/src/main/java/com/yfd/platform/qgc_env/fb/entity/vo/FbTracingPointVo.java @@ -0,0 +1,107 @@ +package com.yfd.platform.qgc_env.fb.entity.vo; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.math.BigDecimal; + +@Data +@Schema(description = "增殖站描点VO") +public class FbTracingPointVo { + + @Schema(description = "站点编码") + private String stcd; + + @Schema(description = "站名") + private String stnm; + + @Schema(description = "站点类型 - 用于锚点弹框显示") + private String sttp; + + @Schema(description = "锚点类型 - 用于锚点浮框显示") + private String sttpMap; + + @Schema(description = "设施类型 用于下拉选构建树级结构") + private String sttpCode; + + @Schema(description = "经度") + private BigDecimal lgtd; + + @Schema(description = "纬度") + private BigDecimal lttd; + + @Schema(description = "高程") + private BigDecimal dtmel; + + @Schema(description = "描点状态 - 用于图例") + private String anchoPointState; + + @Schema(description = "弹框站点名称") + private String titleName; + + @Schema(description = "地图避让") + private Integer distance; + + @Schema(description = "流域编码") + private String rvcd; + + @Schema(description = "行政编码") + private String addvcd; + + @Schema(description = "基地编码") + private String baseId; + + @Schema(description = "设施、断面关联电站编码") + private String rstcd; + + @Schema(description = "设施、断面关联电站编码(冗余)") + private String rstcds; + + @Schema(description = "关联电站名称") + private String ennm; + + @Schema(description = "建设状态：0=规划&1=在建&2=已建") + private Integer bldstt; + + @Schema(description = "运行状态：0=未运行&1=运行") + private Integer status; + + @Schema(description = "运行状态名称") + private String statusName; + + @Schema(description = "计划完成总数(万尾)") + private Long jhCnt; + + @Schema(description = "已完成总数(万尾)") + private Long fished; + + @Schema(description = "未完成总数(万尾)") + private Long unfished; + + @Schema(description = "计划年度") + private String yr; + + @Schema(description = "是否接入：0=未接入 1=已接入") + private Integer dtin; + + @Schema(description = "是否接入名称") + private String dtinName; + + @Schema(description = "达标状态子类型(1=正常运行,2=暂无数据,3=未正常运行)") + private Integer stdSstate; + + @Schema(description = "达标状态子类型名称") + private String stdSstateName; + + @Schema(description = "澜沧江运行状态(特殊处理:1=正常运行,2=暂无数据)") + private Integer lcjStatus; + + @Schema(description = "澜沧江运行状态名称") + private String lcjStatusName; + + @Schema(description = "沿程排序") + private Integer siteStepSort; + + @Schema(description = "站点图片") + private String logo; +} \ No newline at end of file diff --git a/backend/src/main/java/com/yfd/platform/qgc_env/fb/service/FbStationService.java b/backend/src/main/java/com/yfd/platform/qgc_env/fb/service/FbStationService.java index 77cd39aa..e0e19b45 100644 --- a/backend/src/main/java/com/yfd/platform/qgc_env/fb/service/FbStationService.java +++ b/backend/src/main/java/com/yfd/platform/qgc_env/fb/service/FbStationService.java @@ -16,6 +16,7 @@ import com.yfd.platform.qgc_env.fb.entity.vo.FbStInfoResultVo; import com.yfd.platform.qgc_env.fb.entity.vo.FbStationStaticsDataVo; import com.yfd.platform.qgc_env.fb.entity.vo.YearRpStatisticsVo; import com.yfd.platform.qgc_env.fb.entity.vo.FbStationOverviewSecondVo; +import com.yfd.platform.qgc_env.fb.entity.vo.FbTracingPointVo; import com.yfd.platform.qgc_env.fb.entity.vo.TableVo; import java.util.List; @@ -62,4 +63,6 @@ public interface FbStationService { DataSourceResult getFishhatchrecrFishKendoListCust(Integer type, DataSourceRequest dataSourceRequest); DataSourceResult getFishbreedrFishKendoListCust(DataSourceRequest dataSourceRequest); + + DataSourceResult getFbPointKendoListCust(DataSourceRequest dataSourceRequest); } diff --git a/backend/src/main/java/com/yfd/platform/qgc_env/fb/service/impl/FbStationServiceImpl.java b/backend/src/main/java/com/yfd/platform/qgc_env/fb/service/impl/FbStationServiceImpl.java index d3df7885..7963c7c4 100644 --- a/backend/src/main/java/com/yfd/platform/qgc_env/fb/service/impl/FbStationServiceImpl.java +++ b/backend/src/main/java/com/yfd/platform/qgc_env/fb/service/impl/FbStationServiceImpl.java @@ -30,12 +30,14 @@ import com.yfd.platform.qgc_env.fb.entity.vo.FbStInfoResultVo; import com.yfd.platform.qgc_env.fb.entity.vo.FbStationOverviewSecondVo; import com.yfd.platform.qgc_env.fb.entity.vo.FbStationStaticsDataVo; import com.yfd.platform.qgc_env.fb.entity.vo.FbStationStaticsRawVo; +import com.yfd.platform.qgc_env.fb.entity.vo.FbTracingPointVo; import com.yfd.platform.qgc_env.fb.entity.vo.FishbreedRVo; import com.yfd.platform.qgc_env.fb.entity.vo.FishhatchrecRVo; import com.yfd.platform.qgc_env.fb.entity.vo.HeadColunmsVo; import com.yfd.platform.qgc_env.fb.entity.vo.TableVo; import com.yfd.platform.qgc_env.fb.entity.vo.YearRpStatisticsVo; import com.yfd.platform.qgc_env.fb.service.FbStationService; +import com.yfd.platform.qgc_env.wt.utils.SiteAvoidanceUtils; import com.yfd.platform.utils.QgcQueryWrapperUtil; import jakarta.annotation.Resource; import org.springframework.stereotype.Service; @@ -4572,4 +4574,131 @@ public class FbStationServiceImpl implements FbStationService { tableVo.setTotal(total); return tableVo; } + + @Override + public DataSourceResult getFbPointKendoListCust(DataSourceRequest dataSourceRequest) { + DataSourceResult dataSourceResult = new DataSourceResult<>(); + dataSourceResult.setAggregates(new HashMap<>()); + + if (dataSourceRequest == null) { + dataSourceResult.setData(new ArrayList<>()); + dataSourceResult.setTotal(0L); + return dataSourceResult; + } + + DataSourceLoadOptionsBase devRequest = dataSourceRequest.toDevRequest(); + String rstcd = QgcQueryWrapperUtil.getFilterFieldValue(devRequest, "rstcd"); + String sttp = QgcQueryWrapperUtil.getFilterFieldValue(devRequest, "sttp"); + String bldsttCcode = QgcQueryWrapperUtil.getFilterFieldValue(devRequest, "bldsttCcode"); + + if (StrUtil.isEmpty(sttp)) { + dataSourceResult.setData(new ArrayList<>()); + dataSourceResult.setTotal(0L); + return dataSourceResult; + } + + StringBuilder sql = new StringBuilder(); + sql.append("SELECT ") + .append("a.STCD AS stcd, ") + .append("a.STNM AS stnm, ") + .append("a.LOGO AS logo, ") + .append("a.STNM AS titleName, ") + .append("a.STTP AS sttp, ") + .append("a.STTP AS sttpMap, ") + .append("a.STTP AS sttpCode, ") + .append("a.LGTD AS lgtd, ") + .append("a.LTTD AS lttd, ") + .append("a.ELEV AS dtmel, ") + .append("a.BLDSTT_CODE AS bldstt, ") + .append("a.RSTCD AS rstcd, ") + .append("a.RSTCD AS rstcds, ") + .append("a.BASE_ID AS baseId, ") + .append("a.DTIN AS dtin, ") + .append("eng.ENNM AS ennm, ") + .append("eng.RVCD AS rvcd, ") + .append("eng.ADDVCD AS addvcd, ") + .append("NVL(siteSort.SORT, 999999) AS siteStepSort, ") + .append("NVL(along.ORDER_INDEX, 999999) AS rvcdStepSort, ") + .append("NVL(rstSort.SORT, 999999) AS rstcdStepSort, ") + .append("NVL(hb.ORDER_INDEX, 999999) AS baseStepSort, ") + .append("'" + sttp + "' AS anchoPointState, ") + .append("CASE WHEN b.lcjStatus IS NOT NULL THEN 1 ELSE 2 END AS lcjStatus ") + .append("FROM SD_FBRD_B_H a ") + .append("LEFT JOIN SD_ENGINFO_B_H eng ON eng.STCD = a.RSTCD AND NVL(eng.IS_DELETED, 0) = 0 ") + .append("LEFT JOIN SD_HYDROBASE hb ON hb.BASEID = a.BASE_ID AND NVL(hb.IS_DELETED, 0) = 0 ") + .append("LEFT JOIN MS_ALONG_B along ON along.RVCD = eng.HBRVCD AND along.CODE = 'common' AND NVL(along.IS_DELETED, 0) = 0 ") + .append("LEFT JOIN ( ") + .append(" SELECT det.SORT, cfg.RVCD, det.STCD ") + .append(" FROM MS_ALONGDET_B det ") + .append(" INNER JOIN MS_ALONG_B cfg ON det.ALONG_ID = cfg.ID ") + .append(" WHERE NVL(det.IS_DELETED, 0) = 0 AND NVL(cfg.IS_DELETED, 0) = 0 AND cfg.CODE = 'common' ") + .append(") rstSort ON rstSort.RVCD = eng.HBRVCD AND rstSort.STCD = a.RSTCD ") + .append("LEFT JOIN ( ") + .append(" SELECT det.SORT, cfg.RVCD, det.STCD ") + .append(" FROM MS_ALONGDET_B det ") + .append(" INNER JOIN MS_ALONG_B cfg ON det.ALONG_ID = cfg.ID ") + .append(" WHERE NVL(det.IS_DELETED, 0) = 0 AND NVL(cfg.IS_DELETED, 0) = 0 AND cfg.CODE = 'common' ") + .append(") siteSort ON siteSort.RVCD = eng.HBRVCD AND siteSort.STCD = a.STCD ") + .append("LEFT JOIN ( ") + .append(" SELECT t.RSTCD AS stcd, COUNT(1) AS lcjStatus ") + .append(" FROM SD_ENGFR_R t ") + .append(" INNER JOIN SD_RPIMNFISH_R t1 ON t.ID = t1.RPIMN_ID ") + .append(" WHERE (t.TASK_STATUS IS NULL OR t.TASK_STATUS = 'Approved') ") + .append(" AND NVL(t.IS_DELETED, 0) = 0 AND NVL(t1.IS_DELETED, 0) = 0 ") + .append(" AND t.TM BETWEEN ADD_MONTHS(SYSDATE, -12) AND SYSDATE ") + .append(" GROUP BY t.RSTCD ") + .append(") b ON a.STCD = b.stcd ") + .append("WHERE NVL(a.USFL, 1) = 1 ") + .append("AND a.LGTD IS NOT NULL ") + .append("AND a.LTTD IS NOT NULL "); + + Map paramMap = new HashMap<>(); + + if (StrUtil.isNotEmpty(sttp)) { + sql.append(" AND a.STTP = :sttp "); + paramMap.put("sttp", sttp); + } + if (StrUtil.isNotEmpty(rstcd)) { + sql.append(" AND a.RSTCD LIKE '%' || :rstcd || '%' "); + paramMap.put("rstcd", rstcd); + } + if (StrUtil.isNotEmpty(bldsttCcode)) { + sql.append(" AND a.BLDSTT_CODE = :bldsttCcode "); + paramMap.put("bldsttCcode", Integer.parseInt(bldsttCcode)); + } + + sql.append(" ORDER BY NVL(siteSort.SORT, 999999) ASC "); + + Page page = devRequest == null ? null : QgcQueryWrapperUtil.buildPage(devRequest, devRequest.getSkip(), devRequest.getTake()); + List list = microservicDynamicSQLMapper.pageAllListWithResultType(page, sql.toString(), paramMap, FbTracingPointVo.class); + + list = getPointLegend(list); + + SiteAvoidanceUtils.calcSiteMapLev(list, + FbTracingPointVo::getStcd, + FbTracingPointVo::getLgtd, + FbTracingPointVo::getLttd, + FbTracingPointVo::getAnchoPointState, + FbTracingPointVo::setDistance); + + dataSourceResult.setData(list); + dataSourceResult.setTotal(page == null ? list.size() : page.getTotal()); + return dataSourceResult; + } + + private List getPointLegend(List voList) { + for (FbTracingPointVo pointVo : voList) { + Integer bldstt = pointVo.getBldstt(); + String sttp = pointVo.getSttp(); + if (bldstt == null || bldstt != 2) { + if ("FB".equals(sttp)) { + pointVo.setAnchoPointState("fb_incomplete"); + } + if ("SG".equals(sttp)) { + pointVo.setAnchoPointState("sg_incomplete"); + } + } + } + return voList; + } }