完成专项核查拓展查询服务组装

This commit is contained in:
wkc
2026-03-24 23:01:21 +08:00
parent 0dbf5c5ca4
commit 8a6b844509
3 changed files with 377 additions and 9 deletions

View File

@@ -1,5 +1,6 @@
package com.ruoyi.ccdi.project.service.impl;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ruoyi.ccdi.project.domain.CcdiProject;
import com.ruoyi.ccdi.project.domain.dto.CcdiProjectExtendedPurchaseDetailQueryDTO;
import com.ruoyi.ccdi.project.domain.dto.CcdiProjectExtendedPurchaseQueryDTO;
@@ -10,10 +11,13 @@ import com.ruoyi.ccdi.project.domain.dto.CcdiProjectExtendedTransferQueryDTO;
import com.ruoyi.ccdi.project.domain.dto.CcdiProjectFamilyAssetLiabilityDetailQueryDTO;
import com.ruoyi.ccdi.project.domain.dto.CcdiProjectFamilyAssetLiabilityListQueryDTO;
import com.ruoyi.ccdi.project.domain.vo.CcdiProjectExtendedPurchaseDetailVO;
import com.ruoyi.ccdi.project.domain.vo.CcdiProjectExtendedPurchaseListItemVO;
import com.ruoyi.ccdi.project.domain.vo.CcdiProjectExtendedPurchaseListVO;
import com.ruoyi.ccdi.project.domain.vo.CcdiProjectExtendedRecruitmentDetailVO;
import com.ruoyi.ccdi.project.domain.vo.CcdiProjectExtendedRecruitmentListItemVO;
import com.ruoyi.ccdi.project.domain.vo.CcdiProjectExtendedRecruitmentListVO;
import com.ruoyi.ccdi.project.domain.vo.CcdiProjectExtendedTransferDetailVO;
import com.ruoyi.ccdi.project.domain.vo.CcdiProjectExtendedTransferListItemVO;
import com.ruoyi.ccdi.project.domain.vo.CcdiProjectExtendedTransferListVO;
import com.ruoyi.ccdi.project.domain.vo.CcdiProjectFamilyAssetDetailVO;
import com.ruoyi.ccdi.project.domain.vo.CcdiProjectFamilyAssetLiabilityDetailVO;
@@ -72,9 +76,17 @@ public class CcdiProjectSpecialCheckServiceImpl implements ICcdiProjectSpecialCh
@Override
public CcdiProjectExtendedPurchaseListVO getExtendedPurchaseList(CcdiProjectExtendedPurchaseQueryDTO queryDTO) {
ensureProjectExists(queryDTO.getProjectId());
Page<CcdiProjectExtendedPurchaseListItemVO> page = new Page<>(
defaultPageNum(queryDTO.getPageNum()),
defaultPageSize(queryDTO.getPageSize())
);
Page<CcdiProjectExtendedPurchaseListItemVO> resultPage = specialCheckMapper.selectExtendedPurchasePage(page, queryDTO);
CcdiProjectExtendedPurchaseListVO result = new CcdiProjectExtendedPurchaseListVO();
result.setRows(List.of());
result.setTotal(0L);
result.setRows(resultPage == null ? List.of() : defaultList(resultPage.getRecords()));
result.setTotal(resultPage == null ? 0L : resultPage.getTotal());
return result;
}
@@ -82,16 +94,36 @@ public class CcdiProjectSpecialCheckServiceImpl implements ICcdiProjectSpecialCh
public CcdiProjectExtendedPurchaseDetailVO getExtendedPurchaseDetail(
CcdiProjectExtendedPurchaseDetailQueryDTO queryDTO
) {
return new CcdiProjectExtendedPurchaseDetailVO();
ensureProjectExists(queryDTO.getProjectId());
CcdiProjectExtendedPurchaseDetailVO detail = specialCheckMapper.selectExtendedPurchaseDetail(
queryDTO.getProjectId(),
queryDTO.getPurchaseId()
);
if (detail == null) {
throw new ServiceException("当前记录不属于该项目专项核查范围");
}
return detail;
}
@Override
public CcdiProjectExtendedRecruitmentListVO getExtendedRecruitmentList(
CcdiProjectExtendedRecruitmentQueryDTO queryDTO
) {
ensureProjectExists(queryDTO.getProjectId());
Page<CcdiProjectExtendedRecruitmentListItemVO> page = new Page<>(
defaultPageNum(queryDTO.getPageNum()),
defaultPageSize(queryDTO.getPageSize())
);
Page<CcdiProjectExtendedRecruitmentListItemVO> resultPage = specialCheckMapper.selectExtendedRecruitmentPage(
page,
queryDTO
);
CcdiProjectExtendedRecruitmentListVO result = new CcdiProjectExtendedRecruitmentListVO();
result.setRows(List.of());
result.setTotal(0L);
result.setRows(resultPage == null ? List.of() : defaultList(resultPage.getRecords()));
result.setTotal(resultPage == null ? 0L : resultPage.getTotal());
return result;
}
@@ -99,14 +131,31 @@ public class CcdiProjectSpecialCheckServiceImpl implements ICcdiProjectSpecialCh
public CcdiProjectExtendedRecruitmentDetailVO getExtendedRecruitmentDetail(
CcdiProjectExtendedRecruitmentDetailQueryDTO queryDTO
) {
return new CcdiProjectExtendedRecruitmentDetailVO();
ensureProjectExists(queryDTO.getProjectId());
CcdiProjectExtendedRecruitmentDetailVO detail = specialCheckMapper.selectExtendedRecruitmentDetail(
queryDTO.getProjectId(),
queryDTO.getRecruitId()
);
if (detail == null) {
throw new ServiceException("当前记录不属于该项目专项核查范围");
}
return detail;
}
@Override
public CcdiProjectExtendedTransferListVO getExtendedTransferList(CcdiProjectExtendedTransferQueryDTO queryDTO) {
ensureProjectExists(queryDTO.getProjectId());
Page<CcdiProjectExtendedTransferListItemVO> page = new Page<>(
defaultPageNum(queryDTO.getPageNum()),
defaultPageSize(queryDTO.getPageSize())
);
Page<CcdiProjectExtendedTransferListItemVO> resultPage = specialCheckMapper.selectExtendedTransferPage(page, queryDTO);
CcdiProjectExtendedTransferListVO result = new CcdiProjectExtendedTransferListVO();
result.setRows(List.of());
result.setTotal(0L);
result.setRows(resultPage == null ? List.of() : defaultList(resultPage.getRecords()));
result.setTotal(resultPage == null ? 0L : resultPage.getTotal());
return result;
}
@@ -114,7 +163,16 @@ public class CcdiProjectSpecialCheckServiceImpl implements ICcdiProjectSpecialCh
public CcdiProjectExtendedTransferDetailVO getExtendedTransferDetail(
CcdiProjectExtendedTransferDetailQueryDTO queryDTO
) {
return new CcdiProjectExtendedTransferDetailVO();
ensureProjectExists(queryDTO.getProjectId());
CcdiProjectExtendedTransferDetailVO detail = specialCheckMapper.selectExtendedTransferDetail(
queryDTO.getProjectId(),
queryDTO.getId()
);
if (detail == null) {
throw new ServiceException("当前记录不属于该项目专项核查范围");
}
return detail;
}
private void ensureProjectExists(Long projectId) {
@@ -171,4 +229,12 @@ public class CcdiProjectSpecialCheckServiceImpl implements ICcdiProjectSpecialCh
private <T> List<T> defaultList(List<T> list) {
return list == null ? List.of() : list;
}
private long defaultPageNum(Integer pageNum) {
return pageNum == null || pageNum < 1 ? 1L : pageNum.longValue();
}
private long defaultPageSize(Integer pageSize) {
return pageSize == null || pageSize < 1 ? 10L : pageSize.longValue();
}
}