|
@@ -7,6 +7,7 @@ import com.alibaba.druid.sql.dialect.odps.ast.OdpsStatisticClause;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
|
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
import com.google.common.collect.Lists;
|
|
import com.google.common.collect.Lists;
|
|
@@ -94,34 +95,56 @@ public class CwProjectReportArchiveService extends ServiceImpl<CwProjectReportAr
|
|
// 项目经理1
|
|
// 项目经理1
|
|
if (StringUtils.isNotBlank(cwProjectReportArchiveDTO.getCwProjectRecordsDTO().getProjectMasterName())){
|
|
if (StringUtils.isNotBlank(cwProjectReportArchiveDTO.getCwProjectRecordsDTO().getProjectMasterName())){
|
|
List<User> userList = userMapper.selectList(new QueryWrapper<User>().lambda().like(User::getName, cwProjectReportArchiveDTO.getCwProjectRecordsDTO().getProjectMasterName()));
|
|
List<User> userList = userMapper.selectList(new QueryWrapper<User>().lambda().like(User::getName, cwProjectReportArchiveDTO.getCwProjectRecordsDTO().getProjectMasterName()));
|
|
- List<String> userIdList = userList.stream().map(User::getId).collect(Collectors.toList()).stream().distinct().collect(Collectors.toList());
|
|
|
|
- if (CollectionUtil.isNotEmpty(userIdList)){
|
|
|
|
- List<CwProjectRecords> cwProjectRecords = cwProjectRecordsMapper.selectList(new QueryWrapper<CwProjectRecords>().lambda().in(CwProjectRecords::getProjectMasterId, userIdList));
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(userList)){
|
|
|
|
+ List<String> userIdList = userList.stream().map(User::getId).collect(Collectors.toList()).stream().distinct().collect(Collectors.toList());
|
|
|
|
+ if (CollectionUtil.isNotEmpty(userIdList)){
|
|
|
|
+ List<CwProjectRecords> cwProjectRecords = cwProjectRecordsMapper.selectList(new QueryWrapper<CwProjectRecords>().lambda().in(CwProjectRecords::getProjectMasterId, userIdList));
|
|
|
|
+ List<String> projectIds = cwProjectRecords.stream().map(CwProjectRecords::getId).collect(Collectors.toList()).stream().distinct().collect(Collectors.toList());
|
|
|
|
+ if (CollectionUtil.isNotEmpty(projectIds)){
|
|
|
|
+ queryWrapper.in("cw_pa.project_id",projectIds);
|
|
|
|
+ }else{
|
|
|
|
+ return new Page<>();
|
|
|
|
+ }
|
|
|
|
+ }else{
|
|
|
|
+ return new Page<>();
|
|
|
|
+ }
|
|
|
|
+ } else {
|
|
|
|
+ List<CwProjectRecords> cwProjectRecords = cwProjectRecordsMapper.selectList(new QueryWrapper<CwProjectRecords>().lambda().eq(CwProjectRecords::getProjectMasterId, cwProjectReportArchiveDTO.getCwProjectRecordsDTO().getProjectMasterName()));
|
|
List<String> projectIds = cwProjectRecords.stream().map(CwProjectRecords::getId).collect(Collectors.toList()).stream().distinct().collect(Collectors.toList());
|
|
List<String> projectIds = cwProjectRecords.stream().map(CwProjectRecords::getId).collect(Collectors.toList()).stream().distinct().collect(Collectors.toList());
|
|
if (CollectionUtil.isNotEmpty(projectIds)){
|
|
if (CollectionUtil.isNotEmpty(projectIds)){
|
|
queryWrapper.in("cw_pa.project_id",projectIds);
|
|
queryWrapper.in("cw_pa.project_id",projectIds);
|
|
}else{
|
|
}else{
|
|
return new Page<>();
|
|
return new Page<>();
|
|
}
|
|
}
|
|
- }else{
|
|
|
|
- return new Page<>();
|
|
|
|
}
|
|
}
|
|
|
|
+
|
|
}
|
|
}
|
|
// 项目经理2
|
|
// 项目经理2
|
|
if (StringUtils.isNotBlank(cwProjectReportArchiveDTO.getCwProjectRecordsDTO().getRealHeaderName())){
|
|
if (StringUtils.isNotBlank(cwProjectReportArchiveDTO.getCwProjectRecordsDTO().getRealHeaderName())){
|
|
List<User> userList = userMapper.selectList(new QueryWrapper<User>().lambda().like(User::getName, cwProjectReportArchiveDTO.getCwProjectRecordsDTO().getRealHeaderName()));
|
|
List<User> userList = userMapper.selectList(new QueryWrapper<User>().lambda().like(User::getName, cwProjectReportArchiveDTO.getCwProjectRecordsDTO().getRealHeaderName()));
|
|
- List<String> userIdList = userList.stream().map(User::getId).collect(Collectors.toList()).stream().distinct().collect(Collectors.toList());
|
|
|
|
- if (CollectionUtil.isNotEmpty(userIdList)){
|
|
|
|
- List<CwProjectRecords> cwProjectRecords = cwProjectRecordsMapper.selectList(new QueryWrapper<CwProjectRecords>().lambda().in(CwProjectRecords::getRealHeader, userIdList));
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(userList)){
|
|
|
|
+ List<String> userIdList = userList.stream().map(User::getId).collect(Collectors.toList()).stream().distinct().collect(Collectors.toList());
|
|
|
|
+ if (CollectionUtil.isNotEmpty(userIdList)){
|
|
|
|
+ List<CwProjectRecords> cwProjectRecords = cwProjectRecordsMapper.selectList(new QueryWrapper<CwProjectRecords>().lambda().in(CwProjectRecords::getRealHeader, userIdList));
|
|
|
|
+ List<String> projectIds = cwProjectRecords.stream().map(CwProjectRecords::getId).collect(Collectors.toList()).stream().distinct().collect(Collectors.toList());
|
|
|
|
+ if (CollectionUtil.isNotEmpty(projectIds)){
|
|
|
|
+ queryWrapper.in("cw_pa.project_id",projectIds);
|
|
|
|
+ }else{
|
|
|
|
+ return new Page<>();
|
|
|
|
+ }
|
|
|
|
+ }else{
|
|
|
|
+ return new Page<>();
|
|
|
|
+ }
|
|
|
|
+ } else {
|
|
|
|
+ List<CwProjectRecords> cwProjectRecords = cwProjectRecordsMapper.selectList(new QueryWrapper<CwProjectRecords>().lambda().in(CwProjectRecords::getRealHeader, cwProjectReportArchiveDTO.getCwProjectRecordsDTO().getRealHeaderName()));
|
|
List<String> projectIds = cwProjectRecords.stream().map(CwProjectRecords::getId).collect(Collectors.toList()).stream().distinct().collect(Collectors.toList());
|
|
List<String> projectIds = cwProjectRecords.stream().map(CwProjectRecords::getId).collect(Collectors.toList()).stream().distinct().collect(Collectors.toList());
|
|
if (CollectionUtil.isNotEmpty(projectIds)){
|
|
if (CollectionUtil.isNotEmpty(projectIds)){
|
|
queryWrapper.in("cw_pa.project_id",projectIds);
|
|
queryWrapper.in("cw_pa.project_id",projectIds);
|
|
}else{
|
|
}else{
|
|
return new Page<>();
|
|
return new Page<>();
|
|
}
|
|
}
|
|
- }else{
|
|
|
|
- return new Page<>();
|
|
|
|
}
|
|
}
|
|
|
|
+
|
|
}
|
|
}
|
|
// 创建时间
|
|
// 创建时间
|
|
if (ArrayUtil.isNotEmpty(cwProjectReportArchiveDTO.getCreateDates())){
|
|
if (ArrayUtil.isNotEmpty(cwProjectReportArchiveDTO.getCreateDates())){
|