diff --git a/backend/src/main/java/com/yfd/platform/data/controller/FishDraftDataController.java b/backend/src/main/java/com/yfd/platform/data/controller/FishDraftDataController.java index 04a67cc..7f4557c 100644 --- a/backend/src/main/java/com/yfd/platform/data/controller/FishDraftDataController.java +++ b/backend/src/main/java/com/yfd/platform/data/controller/FishDraftDataController.java @@ -1,18 +1,17 @@ package com.yfd.platform.data.controller; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.yfd.platform.common.DataSourceLoadOptionsBase; import com.yfd.platform.common.DataSourceRequest; import com.yfd.platform.config.ResponseResult; import com.yfd.platform.data.domain.FishDraftData; import com.yfd.platform.data.domain.FishImportRequest; import com.yfd.platform.data.domain.FishImportResult; import com.yfd.platform.data.domain.ImportTask; +import com.yfd.platform.data.domain.vo.FishDraftDataVO; import com.yfd.platform.data.service.IFishDraftDataService; import com.yfd.platform.data.service.IFishImportService; import com.yfd.platform.data.service.IImportTaskService; import com.yfd.platform.utils.KendoUtil; -import com.yfd.platform.utils.QgcQueryWrapperUtil; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.tags.Tag; import jakarta.annotation.Resource; @@ -44,17 +43,16 @@ public class FishDraftDataController { private IImportTaskService importTaskService; @PostMapping("/page") - @Operation(summary = "分页查询过鱼数据") + @Operation(summary = "分页查询过鱼数据(关联电站和设施)") public ResponseResult queryPageList(@RequestBody DataSourceRequest dataSourceRequest) { - Page page = KendoUtil.getPage(dataSourceRequest); - Page result = fishDraftDataService.queryPageList(page, dataSourceRequest); + Page result = fishDraftDataService.queryPageList( dataSourceRequest); return ResponseResult.successData(result); } - @GetMapping("/list") - @Operation(summary = "查询过鱼数据列表") - public ResponseResult list() { - List list = fishDraftDataService.list(); + @PostMapping("/list") + @Operation(summary = "查询过鱼数据列表(关联电站和设施,不分页)") + public ResponseResult list(@RequestBody DataSourceRequest dataSourceRequest) { + List list = fishDraftDataService.queryJoinList(dataSourceRequest); return ResponseResult.successData(list); } diff --git a/backend/src/main/java/com/yfd/platform/data/domain/vo/FishDraftDataVO.java b/backend/src/main/java/com/yfd/platform/data/domain/vo/FishDraftDataVO.java new file mode 100644 index 0000000..78ea3d5 --- /dev/null +++ b/backend/src/main/java/com/yfd/platform/data/domain/vo/FishDraftDataVO.java @@ -0,0 +1,202 @@ +package com.yfd.platform.data.domain.vo; + +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + +/** + *

+ * 过鱼数据关联查询VO + *

+ */ +@Data +public class FishDraftDataVO implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * 主键ID + */ + private String id; + + /** + * 过鱼设施编码 + */ + private String stcd; + + /** + * 填报时间 + */ + private Date tm; + + /** + * 鱼类 + */ + private String ftp; + + /** + * 鱼类全长 + */ + private String fsz; + + /** + * 过鱼数量 + */ + private Integer fcnt; + + /** + * 平均体重 + */ + private String fwet; + + /** + * 开始日期 + */ + private Date strdt; + + /** + * 结束日期 + */ + private Date enddt; + + /** + * 游向(上行/下行/上行折返/下行折返) + */ + private String direction; + + /** + * 年份 + */ + private Integer yr; + + /** + * 主要月份 + */ + private Integer mouth; + + /** + * 过鱼视频文件路径 + */ + private String vdpth; + + /** + * 图片文件路径 + */ + private String picpth; + + /** + * 是否鱼苗(0否 1是) + */ + private Integer isfs; + + /** + * 数据来源(MANUAL手工 / IMPORT导入 / AUTO自动) + */ + private String sourceType; + + /** + * 审批批次ID + */ + private Long approvalId; + + /** + * 状态(DRAFT未提交 / SUBMITTED已提交 / APPROVED已通过 / REJECTED已驳回) + */ + private String status; + + /** + * 锁定标识(1锁定不可编辑 0可编辑) + */ + private Integer lockFlag; + + /** + * 提交审批时间 + */ + private Date submitTime; + + /** + * 审批完成时间 + */ + private Date approveTime; + + /** + * 删除标记(0未删除 1已删除) + */ + private Integer deletedFlag; + + /** + * 删除人 + */ + private String deletedBy; + + /** + * 删除时间 + */ + private Date deletedAt; + + /** + * 创建时间 + */ + private Date createdAt; + + /** + * 创建人 + */ + private String createdBy; + + /** + * 更新时间 + */ + private Date updatedAt; + + /** + * 更新人 + */ + private String updatedBy; + + /** + * 设施名称(过鱼设施表) + */ + private String stnm; + + /** + * 过鱼设施类型(过鱼设施表) + */ + private String sttp; + + /** + * 所属电站编码(过鱼设施表) + */ + private String rstcd; + + /** + * 电站名称(电站表) + */ + private String ennm; + + /** + * 所属基地编码(电站表) + */ + private String baseId; + + /** + * 流域编码(电站表) + */ + private String rvcd; + + /** + * 电站经度(电站表) + */ + private Double lgtd; + + /** + * 电站纬度(电站表) + */ + private Double lttd; + + /** + * 排序字段 + */ + private Integer orderIndex; +} \ No newline at end of file diff --git a/backend/src/main/java/com/yfd/platform/data/mapper/FishDraftDataMapper.java b/backend/src/main/java/com/yfd/platform/data/mapper/FishDraftDataMapper.java index a83ccad..e28bfaa 100644 --- a/backend/src/main/java/com/yfd/platform/data/mapper/FishDraftDataMapper.java +++ b/backend/src/main/java/com/yfd/platform/data/mapper/FishDraftDataMapper.java @@ -1,7 +1,9 @@ package com.yfd.platform.data.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.yfd.platform.data.domain.FishDraftData; +import com.yfd.platform.data.domain.vo.FishDraftDataVO; import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Select; @@ -14,6 +16,26 @@ import java.util.List; */ public interface FishDraftDataMapper extends BaseMapper { + /** + * 关联查询过鱼数据(分页) + */ + Page selectJoinPage(Page page, + @Param("stcd") String stcd, + @Param("rstcd") String rstcd, + @Param("baseId") String baseId, + @Param("direction") String direction, + @Param("status") String status, + @Param("ftp") String ftp); + + /** + * 关联查询过鱼数据(不分页) + */ + List selectJoinList(@Param("stcd") String stcd, + @Param("rstcd") String rstcd, + @Param("baseId") String baseId, + @Param("direction") String direction, + @Param("status") String status); + /** * 根据审批批次ID查询草稿数据 */ diff --git a/backend/src/main/java/com/yfd/platform/data/service/IFishDraftDataService.java b/backend/src/main/java/com/yfd/platform/data/service/IFishDraftDataService.java index cfcca39..f85776a 100644 --- a/backend/src/main/java/com/yfd/platform/data/service/IFishDraftDataService.java +++ b/backend/src/main/java/com/yfd/platform/data/service/IFishDraftDataService.java @@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.IService; import com.yfd.platform.common.DataSourceRequest; import com.yfd.platform.data.domain.FishDraftData; +import com.yfd.platform.data.domain.vo.FishDraftDataVO; import java.util.List; @@ -15,9 +16,14 @@ import java.util.List; public interface IFishDraftDataService extends IService { /** - * 分页查询草稿数据 + * 分页查询草稿数据(关联电站和设施表) */ - Page queryPageList(Page page, DataSourceRequest dataSourceRequest); + Page queryPageList(DataSourceRequest dataSourceRequest); + + /** + * 查询草稿数据列表(关联电站和设施表,不分页) + */ + List queryJoinList(DataSourceRequest dataSourceRequest); /** * 根据审批批次ID查询 diff --git a/backend/src/main/java/com/yfd/platform/data/service/impl/FishDraftDataServiceImpl.java b/backend/src/main/java/com/yfd/platform/data/service/impl/FishDraftDataServiceImpl.java index 2abf0ec..dfbd057 100644 --- a/backend/src/main/java/com/yfd/platform/data/service/impl/FishDraftDataServiceImpl.java +++ b/backend/src/main/java/com/yfd/platform/data/service/impl/FishDraftDataServiceImpl.java @@ -5,10 +5,12 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.yfd.platform.common.DataSourceLoadOptionsBase; import com.yfd.platform.common.DataSourceRequest; import com.yfd.platform.data.domain.FishDraftData; +import com.yfd.platform.data.domain.vo.FishDraftDataVO; import com.yfd.platform.data.mapper.FishDraftDataMapper; import com.yfd.platform.data.service.IApprovalChangeLogService; import com.yfd.platform.data.service.IApprovalMainService; import com.yfd.platform.data.service.IFishDraftDataService; +import com.yfd.platform.utils.KendoUtil; import com.yfd.platform.utils.QgcQueryWrapperUtil; import jakarta.annotation.Resource; import org.springframework.stereotype.Service; @@ -36,7 +38,23 @@ public class FishDraftDataServiceImpl extends ServiceImpl queryPageList(Page page, DataSourceRequest dataSourceRequest) { + public Page queryPageList(DataSourceRequest dataSourceRequest) { + Page page = KendoUtil.getPage(dataSourceRequest); + DataSourceLoadOptionsBase loadOptions = dataSourceRequest.toDevRequest(); + String stcd = QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "stcd"); + String rstcd = QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "rstcd"); + String baseId = QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "baseId"); + String ftp = QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "ftp"); + String direction = QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "direction"); + String status = QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "status"); + + Page resultPage = fishDraftDataMapper.selectJoinPage( + page, stcd, rstcd, baseId, direction, status,ftp); + return resultPage; + } + + @Override + public List queryJoinList(DataSourceRequest dataSourceRequest) { DataSourceLoadOptionsBase loadOptions = dataSourceRequest.toDevRequest(); String stcd = QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "stcd"); String rstcd = QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "rstcd"); @@ -44,8 +62,7 @@ public class FishDraftDataServiceImpl extends ServiceImpl + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + D.ID, + D.STCD, + D.TM, + D.FTP, + D.FSZ, + D.FCNT, + D.FWET, + D.STRDT, + D.ENDDT, + D.DIRECTION, + D.YR, + D.MOUTH, + D.VDPTH, + D.PICPTH, + D.ISFS, + D.SOURCE_TYPE, + D.APPROVAL_ID, + D.STATUS, + D.LOCK_FLAG, + D.SUBMIT_TIME, + D.APPROVE_TIME, + D.DELETED_FLAG, + D.DELETED_BY, + D.DELETED_AT, + D.CREATED_AT, + D.CREATED_BY, + D.UPDATED_AT, + D.UPDATED_BY, + F.STNM, + F.STTP, + F.RSTCD, + E.ENNM, + E.BASE_ID, + E.RVCD, + E.LGTD, + E.LTTD, + E.ORDER_INDEX + + + + + + + + +