|
@@ -2,19 +2,11 @@ package com.ozs.plan.service.impl;
|
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
-import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
-import com.github.pagehelper.PageHelper;
|
|
|
-import com.github.pagehelper.PageInfo;
|
|
|
-import com.ozs.base.domain.BaseAgency;
|
|
|
-import com.ozs.base.domain.BaseNoticeType;
|
|
|
-import com.ozs.base.vo.BaseNoticeVo;
|
|
|
import com.ozs.common.core.domain.AjaxResult;
|
|
|
import com.ozs.common.core.domain.entity.SysDept;
|
|
|
import com.ozs.common.core.domain.entity.SysDictData;
|
|
|
-import com.ozs.common.core.domain.entity.SysProcurementStandard;
|
|
|
import com.ozs.common.core.domain.entity.SysRole;
|
|
|
import com.ozs.common.core.domain.entity.SysUser;
|
|
|
import com.ozs.common.core.domain.model.LoginUser;
|
|
@@ -24,6 +16,7 @@ import com.ozs.common.enums.ProjectStatus;
|
|
|
import com.ozs.common.enums.ProjectTypes;
|
|
|
import com.ozs.common.enums.SysFileRefEnum;
|
|
|
import com.ozs.common.exception.ServiceException;
|
|
|
+import com.ozs.common.utils.PageUtils;
|
|
|
import com.ozs.common.utils.SecurityUtils;
|
|
|
import com.ozs.common.utils.StringUtils;
|
|
|
import com.ozs.common.utils.bean.BeanUtils;
|
|
@@ -38,18 +31,12 @@ import com.ozs.pm.doman.PmDemand;
|
|
|
import com.ozs.pm.mapper.PmDemandMapper;
|
|
|
import com.ozs.system.domain.SysFileInfo;
|
|
|
import com.ozs.system.domain.SysFileRef;
|
|
|
-import com.ozs.system.domain.SysOperLog;
|
|
|
-import com.ozs.system.domain.SysUserRole;
|
|
|
import com.ozs.system.domain.vo.responseVo.SysDeptResponseVo;
|
|
|
import com.ozs.system.mapper.SysDeptMapper;
|
|
|
import com.ozs.system.mapper.SysFileRefMapper;
|
|
|
-import com.ozs.system.mapper.SysOperLogMapper;
|
|
|
-import com.ozs.system.mapper.SysProcurementStandardMapper;
|
|
|
import com.ozs.system.mapper.SysRoleMapper;
|
|
|
-import com.ozs.system.mapper.SysUserRoleMapper;
|
|
|
import com.ozs.system.service.ISysDeptService;
|
|
|
import com.ozs.system.service.ISysDictTypeService;
|
|
|
-import com.ozs.system.service.ISysRoleService;
|
|
|
import com.ozs.system.service.ISysUserService;
|
|
|
import com.ozs.system.service.SysFileService;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
@@ -66,8 +53,6 @@ import java.util.HashMap;
|
|
|
import java.util.LinkedHashMap;
|
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
|
-import java.util.Set;
|
|
|
-import java.util.function.Consumer;
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
@@ -98,15 +83,13 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
@Autowired
|
|
|
private ISysUserService userService;
|
|
|
@Autowired
|
|
|
- private SysProcurementStandardMapper sysProcurementStandardMapper;
|
|
|
- @Autowired
|
|
|
private PmDemandMapper pmDemandMapper;
|
|
|
+
|
|
|
@Override
|
|
|
- public PageInfo<PlanYears> selectPlanYearsList(PlanYearsStandardVo vo) {
|
|
|
+ public Page selectPlanYearsList(PlanYearsStandardVo vo) {
|
|
|
PlanYears ofYears = new PlanYears();
|
|
|
List<PlanYears> planYears;
|
|
|
List<PlanYears> planYearsList = new ArrayList<>();
|
|
|
- PageHelper.startPage(vo.getPageNum().intValue(), vo.getPageSize().intValue());
|
|
|
try {
|
|
|
BeanUtils.copyProperties(vo, ofYears);
|
|
|
planYears = planYearsMapper.selectPlanYearsList(ofYears);
|
|
@@ -114,8 +97,8 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
- PageInfo<PlanYears> pageInfo = new PageInfo<PlanYears>(planYearsList);
|
|
|
- return pageInfo;
|
|
|
+ Page pages = PageUtils.getPages(vo.getPageNum().intValue(), vo.getPageSize().intValue(), planYearsList);
|
|
|
+ return pages;
|
|
|
}
|
|
|
|
|
|
@Override
|
|
@@ -158,9 +141,8 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public PageInfo<PlanYears> selectPlanYearsExamineList(PlanYearsStandardVo vo) {
|
|
|
+ public Page selectPlanYearsExamineList(PlanYearsStandardVo vo) {
|
|
|
PlanYears ofYears = new PlanYears();
|
|
|
- PageHelper.startPage(vo.getPageNum().intValue(), vo.getPageSize().intValue());
|
|
|
List<PlanYears> planYears;
|
|
|
List<PlanYears> planYearsList = new ArrayList<>();
|
|
|
try {
|
|
@@ -170,8 +152,8 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
- PageInfo<PlanYears> pageInfo = new PageInfo<PlanYears>(planYearsList);
|
|
|
- return pageInfo;
|
|
|
+ Page pages = PageUtils.getPages(vo.getPageNum().intValue(), vo.getPageSize().intValue(), planYearsList);
|
|
|
+ return pages;
|
|
|
}
|
|
|
|
|
|
@Override
|
|
@@ -269,7 +251,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
if (byId == null) {
|
|
|
return AjaxResult.error("数据查询失败");
|
|
|
}
|
|
|
- SysDeptResponseVo sysDeptResponseVo = (SysDeptResponseVo) deptService.selectDeptById(byId.getPurchaseDeptId()).get("sysDept");
|
|
|
+ SysDeptResponseVo sysDeptResponseVo = (SysDeptResponseVo) deptService.selectDeptById(Long.valueOf(byId.getPurchaseDeptId())).get("sysDept");
|
|
|
byId.setPurchaseDeptName(sysDeptResponseVo.getDeptName());
|
|
|
HashMap<String, Object> map = new HashMap<>();
|
|
|
map.put("red_id", byId.getPlanYearId());
|
|
@@ -353,7 +335,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
//采购单位
|
|
|
SysDept info = deptMapper.checkDeptNameOnlyOne(ofYear.getPurchaseDeptName());
|
|
|
if (!ObjectUtils.isEmpty(info)) {
|
|
|
- ofYear.setPurchaseDeptId(info.getDeptId());
|
|
|
+ ofYear.setPurchaseDeptId(String.valueOf(info.getDeptId()));
|
|
|
} else {
|
|
|
++failureNum;
|
|
|
failureMsg.append("*" + failureNum + "*采购单位“" + ofYear.getPurchaseDeptName() + "”不存在");
|
|
@@ -448,6 +430,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
PlanYears byId = planYearsMapper.getById(vo.getPlanYearId());
|
|
|
PlanQuarter quarters = new PlanQuarter();
|
|
|
BeanUtils.copyProperties(byId, quarters);
|
|
|
+ quarters.setProjectStatus(ProjectStatus.PLANWAITCOMMIT.getCode());
|
|
|
planQuarterMapper.insertPlanQuarter(quarters);
|
|
|
ofYears.setPlanYearId(vo.getPlanYearId());
|
|
|
ofYears.setProjectStatus(ProjectStatus.PLANTOEXAMINE.getCode());
|
|
@@ -554,16 +537,16 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
SysDept sysDept = deptMapper.selectDeptById(sysUser.getDeptId());
|
|
|
List<SysDept> sysDepts = deptMapper.selectChildrenDeptById(sysDept.getDeptId());
|
|
|
List<Long> collect = sysDepts.stream().map(SysDept::getDeptId).collect(Collectors.toList());
|
|
|
- if (collect.size()==0){
|
|
|
+ if (collect.size() == 0) {
|
|
|
collect.add(-1L);
|
|
|
}
|
|
|
QueryWrapper<PlanYears> queryWrapper = new QueryWrapper<>();
|
|
|
queryWrapper
|
|
|
.or(wrapper -> wrapper.lambda().eq(PlanYears::getPurchaseDeptId, sysDept.getDeptId())
|
|
|
- .eq(PlanYears::getIsExcess, IsExcess.NO_EXCESS.getCode()))
|
|
|
+ .eq(PlanYears::getIsExcess, IsExcess.NO_EXCESS.getCode()))
|
|
|
.or(wrapper -> wrapper.lambda().in(PlanYears::getPurchaseDeptId, collect)
|
|
|
- .eq(PlanYears::getIsExcess, IsExcess.EXCESS.getCode()))
|
|
|
- .in("project_status",ProjectStatus.PLANWAIEXAMINE.getCode(),ProjectStatus.PLANTOEXAMINE.getCode());
|
|
|
+ .eq(PlanYears::getIsExcess, IsExcess.EXCESS.getCode()))
|
|
|
+ .in("project_status", ProjectStatus.PLANWAIEXAMINE.getCode(), ProjectStatus.PLANTOEXAMINE.getCode());
|
|
|
planYears = planYearsMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
@@ -583,7 +566,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
SysDept sysDept = deptMapper.selectDeptById(sysUser.getDeptId());
|
|
|
QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
|
queryWrapper.eq("purchase_dept_id", sysDept.getDeptId());
|
|
|
- pmDemands =pmDemandMapper.selectList(queryWrapper);
|
|
|
+ pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
@@ -602,7 +585,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
SysDept sysDept = deptMapper.selectDeptById(sysUser.getDeptId());
|
|
|
List<SysDept> sysDepts = deptMapper.selectChildrenDeptById(sysDept.getDeptId());
|
|
|
List<Long> collect = sysDepts.stream().map(SysDept::getDeptId).collect(Collectors.toList());
|
|
|
- if (collect.size()==0){
|
|
|
+ if (collect.size() == 0) {
|
|
|
collect.add(-1L);
|
|
|
}
|
|
|
QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
@@ -611,7 +594,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
.eq(PmDemand::getIsExcess, IsExcess.NO_EXCESS.getCode()))
|
|
|
.or(wrapper -> wrapper.lambda().in(PmDemand::getPurchaseDeptId, collect)
|
|
|
.eq(PmDemand::getIsExcess, IsExcess.EXCESS.getCode()))
|
|
|
- .in("project_status",PmProjectStatus.DEMAND_WAIT_AUDIT.getCode(),PmProjectStatus.DEMAND_AUDIT_RETURN.getCode());
|
|
|
+ .in("project_status", PmProjectStatus.DEMAND_WAIT_AUDIT.getCode(), PmProjectStatus.DEMAND_AUDIT_RETURN.getCode());
|
|
|
pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
@@ -631,8 +614,8 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
SysDept sysDept = deptMapper.selectDeptById(sysUser.getDeptId());
|
|
|
QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
|
queryWrapper.eq("purchase_dept_id", sysDept.getDeptId());
|
|
|
- queryWrapper.in("project_status",PmProjectStatus.CONTRACT_WAIT_FILL.getCode(),PmProjectStatus.UNDER_CONSTRUCTION.getCode());
|
|
|
- pmDemands =pmDemandMapper.selectList(queryWrapper);
|
|
|
+ queryWrapper.in("project_status", PmProjectStatus.CONTRACT_WAIT_FILL.getCode(), PmProjectStatus.UNDER_CONSTRUCTION.getCode());
|
|
|
+ pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
@@ -651,8 +634,8 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
SysDept sysDept = deptMapper.selectDeptById(sysUser.getDeptId());
|
|
|
QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
|
queryWrapper.eq("purchase_dept_id", sysDept.getDeptId());
|
|
|
- queryWrapper.in("project_status",PmProjectStatus.UNDER_CONSTRUCTION.getCode(),PmProjectStatus.COMPLETION_CONSTRUCTION.getCode());
|
|
|
- pmDemands =pmDemandMapper.selectList(queryWrapper);
|
|
|
+ queryWrapper.in("project_status", PmProjectStatus.UNDER_CONSTRUCTION.getCode(), PmProjectStatus.COMPLETION_CONSTRUCTION.getCode());
|
|
|
+ pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
@@ -671,7 +654,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
SysDept sysDept = deptMapper.selectDeptById(sysUser.getDeptId());
|
|
|
List<SysDept> sysDepts = deptMapper.selectChildrenDeptById(sysDept.getDeptId());
|
|
|
List<Long> collect = sysDepts.stream().map(SysDept::getDeptId).collect(Collectors.toList());
|
|
|
- if (collect.size()==0){
|
|
|
+ if (collect.size() == 0) {
|
|
|
collect.add(-1L);
|
|
|
}
|
|
|
QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
@@ -680,7 +663,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
.eq(PmDemand::getIsExcess, IsExcess.NO_EXCESS.getCode()))
|
|
|
.or(wrapper -> wrapper.lambda().in(PmDemand::getPurchaseDeptId, collect)
|
|
|
.eq(PmDemand::getIsExcess, IsExcess.EXCESS.getCode()))
|
|
|
- .in("project_status",PmProjectStatus.TASK_WAIT_RELEASE.getCode(),
|
|
|
+ .in("project_status", PmProjectStatus.TASK_WAIT_RELEASE.getCode(),
|
|
|
PmProjectStatus.WAIT_SELECT_AGENT.getCode(),
|
|
|
PmProjectStatus.WAIT_UPLOAD_BID_FILE.getCode(),
|
|
|
PmProjectStatus.WAIT_ANNOUNCEMENT.getCode(),
|
|
@@ -707,7 +690,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
SysDept sysDept = deptMapper.selectDeptById(sysUser.getDeptId());
|
|
|
List<SysDept> sysDepts = deptMapper.selectChildrenDeptById(sysDept.getDeptId());
|
|
|
List<Long> collect = sysDepts.stream().map(SysDept::getDeptId).collect(Collectors.toList());
|
|
|
- if (collect.size()==0){
|
|
|
+ if (collect.size() == 0) {
|
|
|
collect.add(-1L);
|
|
|
}
|
|
|
QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
@@ -743,7 +726,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
SysDept sysDept = deptMapper.selectDeptById(sysUser.getDeptId());
|
|
|
List<SysDept> sysDepts = deptMapper.selectChildrenDeptById(sysDept.getDeptId());
|
|
|
List<Long> collect = sysDepts.stream().map(SysDept::getDeptId).collect(Collectors.toList());
|
|
|
- if (collect.size()==0){
|
|
|
+ if (collect.size() == 0) {
|
|
|
collect.add(-1L);
|
|
|
}
|
|
|
QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
@@ -752,7 +735,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
.eq(PmDemand::getIsExcess, IsExcess.NO_EXCESS.getCode()))
|
|
|
.or(wrapper -> wrapper.lambda().in(PmDemand::getPurchaseDeptId, collect)
|
|
|
.eq(PmDemand::getIsExcess, IsExcess.EXCESS.getCode()))
|
|
|
- .lt("project_status",PmProjectStatus.CONTRACT_WAIT_FILL.getCode());
|
|
|
+ .lt("project_status", PmProjectStatus.CONTRACT_WAIT_FILL.getCode());
|
|
|
pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
@@ -772,7 +755,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
SysDept sysDept = deptMapper.selectDeptById(sysUser.getDeptId());
|
|
|
List<SysDept> sysDepts = deptMapper.selectChildrenDeptById(sysDept.getDeptId());
|
|
|
List<Long> collect = sysDepts.stream().map(SysDept::getDeptId).collect(Collectors.toList());
|
|
|
- if (collect.size()==0){
|
|
|
+ if (collect.size() == 0) {
|
|
|
collect.add(-1L);
|
|
|
}
|
|
|
QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
@@ -781,7 +764,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
.eq(PmDemand::getIsExcess, IsExcess.NO_EXCESS.getCode()))
|
|
|
.or(wrapper -> wrapper.lambda().in(PmDemand::getPurchaseDeptId, collect)
|
|
|
.eq(PmDemand::getIsExcess, IsExcess.EXCESS.getCode()))
|
|
|
- .gt("project_status",PmProjectStatus.CONTRACT_WAIT_FILL.getCode());
|
|
|
+ .gt("project_status", PmProjectStatus.CONTRACT_WAIT_FILL.getCode());
|
|
|
pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
@@ -826,7 +809,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
HashMap<String, String> purchaseServices = planEnums.get("purchaseServices");
|
|
|
List<PlanYears> list = new ArrayList<PlanYears>();
|
|
|
for (PlanYears planYear : planYears) {
|
|
|
- SysDeptResponseVo sysDeptResponseVo = (SysDeptResponseVo) deptService.selectDeptById(planYear.getPurchaseDeptId()).get("sysDept");
|
|
|
+ SysDeptResponseVo sysDeptResponseVo = (SysDeptResponseVo) deptService.selectDeptById(Long.valueOf(planYear.getPurchaseDeptId())).get("sysDept");
|
|
|
planYear.setPurchaseDeptName(sysDeptResponseVo.getDeptName());
|
|
|
|
|
|
for (Map.Entry<String, String> entry : projectTypesMap.entrySet()) {
|