feat: 查询水生生态断面的年份及是否鱼类,水温,水质,流速数据

backend/src/main/java/com/yfd/platform/qgc_env/wte/controller/WeFishController.java

@@ -7,10 +7,7 @@ import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.annotation.Resource;
 import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.*;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
 
 @RestController
 @RequestMapping("/wte")
@@ -158,4 +155,10 @@ public class WeFishController {
     public ResponseResult getTeSpecialAnimalList(@RequestBody DataSourceRequest dataSourceRequest) {
         return ResponseResult.successData(weFishService.getTeSpecialAnimalList(dataSourceRequest));
     }
+
+    @GetMapping("/getWeDefaultData")
+    @Operation(summary = "查询水生生态断面的年份及是否鱼类,水温,水质,流速数据")
+    public ResponseResult getWeDefaultData(@RequestParam("stcd") String stcd) {
+        return ResponseResult.successData(weFishService.getWeDefaultData(stcd));
+    }
 }

backend/src/main/java/com/yfd/platform/qgc_env/wte/entity/vo/WeDefaultDataVo.java

@@ -0,0 +1,16 @@
+package com.yfd.platform.qgc_env.wte.entity.vo;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+@Data
+@Schema(description = "水生生态断面默认数据实体类")
+public class WeDefaultDataVo {
+
+    private String yr;
+    private Integer hasFtp;
+    private Integer hasFv;
+    private Integer hasWq;
+    private Integer hasWt;
+
+}

backend/src/main/java/com/yfd/platform/qgc_env/wte/service/WeFishService.java

@@ -2,24 +2,7 @@ package com.yfd.platform.qgc_env.wte.service;
 
 import com.yfd.platform.common.DataSourceRequest;
 import com.yfd.platform.common.DataSourceResult;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishListQgcVo;
+import com.yfd.platform.qgc_env.wte.entity.vo.*;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishListStatQgcVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeCompareBarTableVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeEnvmAutoMonitorVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishDetailVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishHbbQgcDetailVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeMsstbprptVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishPageTableVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishPointQgcVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishStatQgcVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishStatTabVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishTQgcVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeStaticsVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeTeSpecialAnimalVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeVmsstbprptVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeWvaDefaultVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeWvaQgcVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeWvaYearQgcVo;
 
 import java.util.List;
 import java.util.Map;
@@ -71,4 +54,6 @@ public interface WeFishService {
     DataSourceResult<WeFishPointQgcVo> getQgcWeFishPoint(DataSourceRequest dataSourceRequest);
 
     DataSourceResult<WeTeSpecialAnimalVo> getTeSpecialAnimalList(DataSourceRequest dataSourceRequest);
+
+    List<WeDefaultDataVo> getWeDefaultData(String stcd);
 }

backend/src/main/java/com/yfd/platform/qgc_env/wte/service/impl/WeFishServiceImpl.java

@@ -10,28 +10,7 @@ import com.yfd.platform.common.DataSourceResult;
 import com.yfd.platform.common.GroupHelper;
 import com.yfd.platform.common.GroupingInfo;
 import com.yfd.platform.common.MicroservicDynamicSQLMapper;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeCompareBarHeadColumnVo;
+import com.yfd.platform.qgc_env.wte.entity.vo.*;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeCompareBarTableVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeCompareBarVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeEnvmAutoMonitorVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishListQgcVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishListStatQgcVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishDetailVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishHbbQgcDetailVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishPageQgcVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishPageTableVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeMsstbprptVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishPointQgcVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishStatQgcVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishStatTabVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeFishTQgcVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeRvcdYearVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeStaticsVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeTeSpecialAnimalVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeVmsstbprptVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeWvaDefaultVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeWvaQgcVo;
-import com.yfd.platform.qgc_env.wte.entity.vo.WeWvaYearQgcVo;
 import com.yfd.platform.qgc_env.wte.service.WeFishService;
 import com.yfd.platform.utils.QgcQueryWrapperUtil;
 import jakarta.annotation.Resource;
@@ -1123,6 +1102,58 @@ public class WeFishServiceImpl implements WeFishService {
         return result;
     }
 
+    @Override
+    public List<WeDefaultDataVo> getWeDefaultData(String stcd) {
+        String sql = "SELECT\n" +
+                "\ta.stcd,\n" +
+                "\tTO_CHAR( a.TM, 'yyyy' ) AS yr,\n" +
+                "CASE\n" +
+                "\t\t\n" +
+                "\t\tWHEN COUNT( b.ID ) > 0 THEN\n" +
+                "\t\t1 ELSE 0 \n" +
+                "\tEND AS hasFtp,\n" +
+                "CASE\n" +
+                "\t\t\n" +
+                "\t\tWHEN COUNT( c.ID ) > 0 THEN\n" +
+                "\t\t1 ELSE 0 \n" +
+                "\tEND AS hasFv,\n" +
+                "CASE\n" +
+                "\t\t\n" +
+                "\t\tWHEN COUNT( d.ID ) > 0 THEN\n" +
+                "\t\t1 ELSE 0 \n" +
+                "\tEND AS hasWq,\n" +
+                "CASE\n" +
+                "\t\t\n" +
+                "\t\tWHEN COUNT( e.ID ) > 0 THEN\n" +
+                "\t\t1 ELSE 0 \n" +
+                "\tEND AS hasWt \n" +
+                "FROM\n" +
+                "\tSD_WE_R a\n" +
+                "\tLEFT JOIN SD_WEFISH_R b ON a.ID = b.WER_ID \n" +
+                "\tAND b.IS_DELETED = 0\n" +
+                "\tLEFT JOIN SD_WEFV_R c ON a.ID = c.WER_ID \n" +
+                "\tAND c.IS_DELETED = 0\n" +
+                "\tLEFT JOIN SD_WEWQ_R d ON a.ID = d.WER_ID \n" +
+                "\tAND d.IS_DELETED = 0\n" +
+                "\tLEFT JOIN SD_WEWT_R e ON a.ID = e.WER_ID \n" +
+                "\tAND e.IS_DELETED = 0 \n" +
+                "WHERE\n" +
+                "\t1 = 1 \n" +
+                "\tAND a.IS_DELETED = 0 \n" +
+                "\tAND a.stcd = #{map.stcd} \n" +
+                "GROUP BY\n" +
+                "\ta.stcd,\n" +
+                "\tTO_CHAR( a.TM, 'yyyy' ) \n" +
+                "ORDER BY\n" +
+                "\tTO_CHAR( a.TM, 'yyyy' ) DESC,\n" +
+                "\ta.stcd\n" +
+                "\n";
+        Map<String, Object> paramMap = new HashMap<>();
+        paramMap.put("stcd", stcd);
+        List<WeDefaultDataVo> oneBySqlWithResultType = microservicDynamicSQLMapper.getAllListWithResultType(sql, paramMap, WeDefaultDataVo.class);
+        return oneBySqlWithResultType;
+    }
+
     private String buildWeFishQgcGroupSql(String baseSql, GroupingInfo[] groupInfos) {
         if (groupInfos == null || groupInfos.length == 0) {
             return baseSql;