|
@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.zjugis.framework.common.pojo.CommonResult;
|
|
import com.zjugis.framework.common.pojo.CommonResult;
|
|
import com.zjugis.framework.mybatis.core.query.LambdaQueryWrapperX;
|
|
import com.zjugis.framework.mybatis.core.query.LambdaQueryWrapperX;
|
|
|
|
+import com.zjugis.framework.security.core.util.SecurityFrameworkUtils;
|
|
import com.zjugis.module.adm.controller.admin.report.vo.base.ReportCreateReqVO;
|
|
import com.zjugis.module.adm.controller.admin.report.vo.base.ReportCreateReqVO;
|
|
import com.zjugis.module.adm.controller.admin.report.vo.workload.*;
|
|
import com.zjugis.module.adm.controller.admin.report.vo.workload.*;
|
|
import com.zjugis.module.adm.convert.report.ReportConvert;
|
|
import com.zjugis.module.adm.convert.report.ReportConvert;
|
|
@@ -15,6 +16,8 @@ import com.zjugis.module.adm.remote.dto.ProjectDto;
|
|
import com.zjugis.module.adm.remote.vo.ProjectVO;
|
|
import com.zjugis.module.adm.remote.vo.ProjectVO;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
|
import javax.annotation.Resource;
|
|
|
|
+
|
|
|
|
+import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.validation.annotation.Validated;
|
|
import org.springframework.validation.annotation.Validated;
|
|
|
|
|
|
import java.util.*;
|
|
import java.util.*;
|
|
@@ -44,18 +47,19 @@ public class ReportWorkloadServiceImpl implements ReportWorkloadService {
|
|
@Override
|
|
@Override
|
|
public List<ReportWorkloadRespVO> getReportWorkloadByRId(Long reportId) {
|
|
public List<ReportWorkloadRespVO> getReportWorkloadByRId(Long reportId) {
|
|
List<ReportWorkloadRespVO> reportWorkloadList = ReportWorkloadConvert.INSTANCE.convertList(
|
|
List<ReportWorkloadRespVO> reportWorkloadList = ReportWorkloadConvert.INSTANCE.convertList(
|
|
- reportWorkloadMapper.selectList(new LambdaQueryWrapperX<ReportWorkloadDO>()
|
|
|
|
- .eqIfPresent(ReportWorkloadDO::getReportId, reportId)));
|
|
|
|
|
|
+ reportWorkloadMapper.selectList(new LambdaQueryWrapperX<ReportWorkloadDO>().eqIfPresent(ReportWorkloadDO::getReportId, reportId)));
|
|
ProjectDto projectDto = new ProjectDto();
|
|
ProjectDto projectDto = new ProjectDto();
|
|
projectDto.setPageNo(1);
|
|
projectDto.setPageNo(1);
|
|
projectDto.setPageSize(-1);
|
|
projectDto.setPageSize(-1);
|
|
-// projectDto.setUserId(SecurityFrameworkUtils.getLoginUserId());
|
|
|
|
|
|
+ projectDto.setUserId(SecurityFrameworkUtils.getLoginUserId());
|
|
CommonResult<Page<ProjectVO>> projectPage = projectClient.getProjectPage(projectDto);
|
|
CommonResult<Page<ProjectVO>> projectPage = projectClient.getProjectPage(projectDto);
|
|
- List<ProjectVO> projectList = projectPage.getData().getRecords();
|
|
|
|
- reportWorkloadList.forEach(report->{
|
|
|
|
- Optional<ProjectVO> projectOptional = projectList.stream().filter(c -> c.getId().equals(report.getProjectId())).findFirst();
|
|
|
|
- report.setProjectName(projectOptional.get().getXmmc());
|
|
|
|
- });
|
|
|
|
|
|
+ if(projectPage.isSuccess()){
|
|
|
|
+ List<ProjectVO> projectList = projectPage.getData().getRecords();
|
|
|
|
+ reportWorkloadList.forEach(report->{
|
|
|
|
+ Optional<ProjectVO> projectOptional = projectList.stream().filter(c -> c.getId().equals(report.getProjectId())).findFirst();
|
|
|
|
+ report.setProjectName(projectOptional.get().getXmmc());
|
|
|
|
+ });
|
|
|
|
+ }
|
|
return reportWorkloadList;
|
|
return reportWorkloadList;
|
|
}
|
|
}
|
|
|
|
|
|
@@ -69,16 +73,18 @@ public class ReportWorkloadServiceImpl implements ReportWorkloadService {
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
|
+ @Transactional
|
|
public void batchCreateReportWorkload(ReportCreateReqVO reportRequestVO) {
|
|
public void batchCreateReportWorkload(ReportCreateReqVO reportRequestVO) {
|
|
|
|
+ Long reportId = reportRequestVO.getReportId();
|
|
//删除之前的工作量
|
|
//删除之前的工作量
|
|
LambdaQueryWrapper<ReportWorkloadDO> queryWrapper = new LambdaQueryWrapper<>();
|
|
LambdaQueryWrapper<ReportWorkloadDO> queryWrapper = new LambdaQueryWrapper<>();
|
|
- queryWrapper.eq(ReportWorkloadDO::getReportId, reportRequestVO.getReportId());
|
|
|
|
|
|
+ queryWrapper.eq(ReportWorkloadDO::getReportId, reportId);
|
|
reportWorkloadMapper.delete(queryWrapper);
|
|
reportWorkloadMapper.delete(queryWrapper);
|
|
|
|
|
|
//新增工作量
|
|
//新增工作量
|
|
- List<ReportWorkloadDO> workloadDOList = ReportConvert.INSTANCE.convertWLoadReq(reportRequestVO.getWeeklyWorkloadList());
|
|
|
|
- workloadDOList.forEach(c->c.setReportId(reportRequestVO.getReportId()));
|
|
|
|
- reportWorkloadMapper.saveOrUpdateBatch(workloadDOList);
|
|
|
|
|
|
+ List<ReportWorkloadDO> workloadList = ReportConvert.INSTANCE.convertWLoadReq(reportRequestVO.getWeeklyWorkloadList());
|
|
|
|
+ workloadList.forEach(c->c.setReportId(reportId));
|
|
|
|
+ reportWorkloadMapper.saveOrUpdateBatch(workloadList);
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|