|
@@ -47,13 +47,12 @@ import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
import org.springframework.util.ObjectUtils;
|
|
|
|
|
|
-import javax.annotation.Resource;
|
|
|
-import javax.servlet.http.HttpServletRequest;
|
|
|
import javax.validation.Validator;
|
|
|
import java.math.BigDecimal;
|
|
|
import java.text.ParseException;
|
|
|
import java.text.SimpleDateFormat;
|
|
|
import java.util.ArrayList;
|
|
|
+import java.util.Arrays;
|
|
|
import java.util.Date;
|
|
|
import java.util.HashMap;
|
|
|
import java.util.LinkedHashMap;
|
|
@@ -122,7 +121,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
private SysFileRefService sysFileRefService;
|
|
|
|
|
|
@Override
|
|
|
- public List<PlanYearsResponseVo> selectPlanYearsListEXP(PlanYearsStandardVo vo) {
|
|
|
+ public List<PlanYearsResponseVo> selectPlanYearsListEXP(PlanYearsStandardVo vo, LoginUser loginUser) {
|
|
|
List<PlanYears> list = new ArrayList<>();
|
|
|
List<PlanYearsResponseVo> planYearsList = new ArrayList<>();
|
|
|
try {
|
|
@@ -149,6 +148,38 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
lw.le(PlanYears::getPlanDemandSubTime, vo.getEndTime());
|
|
|
}
|
|
|
lw.eq(PlanYears::getDelFlay, DataIsDelete.DataNOTDelete.getCode());
|
|
|
+ // 添加数据权限
|
|
|
+ List<String> roleKeys = loginUser.getUser().getRoles().stream().map(SysRole::getRoleKey).collect(Collectors.toList());
|
|
|
+ if (roleKeys.contains(Constants.DEMAND_UNIT)) {
|
|
|
+ // 需求单位
|
|
|
+ /*(purchase_dept_id = 当前用户deptID) */
|
|
|
+ lw.eq(PlanYears::getPurchaseDeptId, loginUser.getDeptId());
|
|
|
+ } else if (roleKeys.contains(Constants.PURCHASING_MANAGEMENT)
|
|
|
+ || roleKeys.contains(Constants.PURCHASE_SERVICES)) {
|
|
|
+ // 采购管理部门 或 采购办
|
|
|
+ SysDept sysDept = new SysDept();
|
|
|
+ sysDept.setParentId(loginUser.getDeptId());
|
|
|
+ sysDept.setStatus("0");
|
|
|
+ List<Long> childDeptIds = deptService.selectDeptList(sysDept)
|
|
|
+ .stream()
|
|
|
+ .map(SysDept::getDeptId)
|
|
|
+ .collect(Collectors.toList());
|
|
|
+ if (ObjectUtils.isEmpty(childDeptIds)) {
|
|
|
+ lw.and((wrapper) -> {
|
|
|
+ wrapper.eq(PlanYears::getIsExcess, 0);
|
|
|
+ wrapper.eq(PlanYears::getPurchaseDeptId, loginUser.getDeptId());
|
|
|
+ });
|
|
|
+ } else {
|
|
|
+ lw.and((wrapper) -> {
|
|
|
+ wrapper.eq(PlanYears::getIsExcess, 0);
|
|
|
+ wrapper.eq(PlanYears::getPurchaseDeptId, loginUser.getDeptId());
|
|
|
+ })
|
|
|
+ .or((wrapper) -> {
|
|
|
+ wrapper.eq(PlanYears::getIsExcess, 1);
|
|
|
+ wrapper.in(PlanYears::getPurchaseDeptId, childDeptIds);
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
Page<PlanYears> page = planYearsMapper.selectPage(new Page<PlanYears>(num, size, false), lw);
|
|
|
list.addAll(page.getRecords());
|
|
|
size = page.getRecords().size();
|
|
@@ -162,7 +193,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public List<PlanYearsResponseVo> selectPlanYearsExamineListEXP(PlanYearsStandardVo vo) {
|
|
|
+ public List<PlanYearsResponseVo> selectPlanYearsExamineListEXP(PlanYearsStandardVo vo, LoginUser loginUser) {
|
|
|
List<PlanYears> list = new ArrayList<>();
|
|
|
List<PlanYearsResponseVo> planYearsList = new ArrayList<>();
|
|
|
try {
|
|
@@ -191,6 +222,38 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
lw.le(PlanYears::getPlanDemandSubTime, vo.getEndTime());
|
|
|
}
|
|
|
lw.eq(PlanYears::getDelFlay, DataIsDelete.DataNOTDelete);
|
|
|
+ // 添加数据权限
|
|
|
+ List<String> roleKeys = loginUser.getUser().getRoles().stream().map(SysRole::getRoleKey).collect(Collectors.toList());
|
|
|
+ if (roleKeys.contains(Constants.DEMAND_UNIT)) {
|
|
|
+ // 需求单位
|
|
|
+ /*(purchase_dept_id = 当前用户deptID) */
|
|
|
+ lw.eq(PlanYears::getPurchaseDeptId, loginUser.getDeptId());
|
|
|
+ } else if (roleKeys.contains(Constants.PURCHASING_MANAGEMENT)
|
|
|
+ || roleKeys.contains(Constants.PURCHASE_SERVICES)) {
|
|
|
+ // 采购管理部门 或 采购办
|
|
|
+ SysDept sysDept = new SysDept();
|
|
|
+ sysDept.setParentId(loginUser.getDeptId());
|
|
|
+ sysDept.setStatus("0");
|
|
|
+ List<Long> childDeptIds = deptService.selectDeptList(sysDept)
|
|
|
+ .stream()
|
|
|
+ .map(SysDept::getDeptId)
|
|
|
+ .collect(Collectors.toList());
|
|
|
+ if (ObjectUtils.isEmpty(childDeptIds)) {
|
|
|
+ lw.and((wrapper) -> {
|
|
|
+ wrapper.eq(PlanYears::getIsExcess, 0);
|
|
|
+ wrapper.eq(PlanYears::getPurchaseDeptId, loginUser.getDeptId());
|
|
|
+ });
|
|
|
+ } else {
|
|
|
+ lw.and((wrapper) -> {
|
|
|
+ wrapper.eq(PlanYears::getIsExcess, 0);
|
|
|
+ wrapper.eq(PlanYears::getPurchaseDeptId, loginUser.getDeptId());
|
|
|
+ })
|
|
|
+ .or((wrapper) -> {
|
|
|
+ wrapper.eq(PlanYears::getIsExcess, 1);
|
|
|
+ wrapper.in(PlanYears::getPurchaseDeptId, childDeptIds);
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
Page<PlanYears> page = planYearsMapper.selectPage(new Page<PlanYears>(num, size, false), lw);
|
|
|
list.addAll(page.getRecords());
|
|
|
size = page.getRecords().size();
|
|
@@ -216,7 +279,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
//判断是否为超额计划
|
|
|
- ofYears.setIsExcess(isExcessOrNo(ofYears.getProjectType(), ofYears.getEvaluation()));
|
|
|
+ ofYears.setIsExcess(deptService.isExcessOrNo(ofYears.getProjectType(), ofYears.getEvaluation(), Long.valueOf(ofYears.getPurchaseDeptId())));
|
|
|
ofYears.setProjectStatus(ProjectStatus.PLANWAITCOMMIT.getCode());
|
|
|
ofYears.setCreateTime(new Date());
|
|
|
planYearsMapper.insertPlanYears(ofYears);
|
|
@@ -259,10 +322,10 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
}
|
|
|
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());
|
|
|
- map.put("type", SysFileRefEnum.PLAN_YEAR.getType());
|
|
|
- List<SysFileRef> fileRefs = sysFileRefMapper.selectByMap(map);
|
|
|
+ LambdaQueryWrapper<SysFileRef> lw = new LambdaQueryWrapper<>();
|
|
|
+ lw.eq(SysFileRef::getRedId, yearsStandardVo.getPlanYearId());
|
|
|
+ lw.in(SysFileRef::getType, Arrays.asList(SysFileRefEnum.PLAN_YEAR.getType(), SysFileRefEnum.PLAN_YEAR_EXAMINE.getType()));
|
|
|
+ List<SysFileRef> fileRefs = sysFileRefMapper.selectList(lw);
|
|
|
List<SysFileInfo> fileInfos = new ArrayList<>();
|
|
|
BeanUtils.copyProperties(byId, responseVo);
|
|
|
if (!ObjectUtils.isEmpty(fileRefs)) {
|
|
@@ -287,7 +350,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
- ofYears.setIsExcess(isExcessOrNo(ofYears.getProjectType(), ofYears.getEvaluation()));
|
|
|
+ ofYears.setIsExcess(deptService.isExcessOrNo(ofYears.getProjectType(), ofYears.getEvaluation(), Long.valueOf(ofYears.getPurchaseDeptId())));
|
|
|
ofYears.setUpdateTime(new Date());
|
|
|
planYearsMapper.updateInfoById(ofYears);
|
|
|
List<SysFileRef> sysFileRefs = yearsStandardVo.getSysFileRefs();
|
|
@@ -365,20 +428,12 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
}
|
|
|
ofYear.setProjectAttr(builder.toString());
|
|
|
ofYear.setPurchaseServices(purchaseServices.get(ofYear.getPurchaseServices()));
|
|
|
- ofYear.setIsExcess(isExcessOrNo(ofYear.getProjectType(), ofYear.getEvaluation()));
|
|
|
+ ofYear.setIsExcess(deptService.isExcessOrNo(ofYear.getProjectType(), ofYear.getEvaluation(), Long.valueOf(ofYear.getPurchaseDeptId())));
|
|
|
ofYear.setCreated(String.valueOf(loginUser.getUserId()));
|
|
|
ofYear.setCreateTime(new Date());
|
|
|
planYearsMapper.insertPlanYears(ofYear);
|
|
|
successNum++;
|
|
|
successMsg.append("*" + successNum + "、项目 " + ofYear.getProjectName() + " 导入成功!");
|
|
|
- //} else if (isUpdateSupport) {
|
|
|
- // PlanYears years = plan.get(0);
|
|
|
- // BeanValidators.validateWithException(validator, ofYear);
|
|
|
- // years.setCreateTime(new Date());
|
|
|
- // years.setProjectStatus(ProjectStatus.PLANWAITCOMMIT.getCode());
|
|
|
- // planYearsMapper.updateById(years);
|
|
|
- // successNum++;
|
|
|
- // successMsg.append("<br/>" + successNum + "、项目 " + ofYear.getProjectName() + " 更新成功");
|
|
|
} else {
|
|
|
failureNum++;
|
|
|
failureMsg.append(failureNum + "*项目 " + ofYear.getProjectName() + " 已存在!/n");
|
|
@@ -401,28 +456,6 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
|
|
|
@Override
|
|
|
public AjaxResult commit(PlanYearsStandardVo yearsStandardVo) {
|
|
|
- //PlanYears byId = PlanYearsMapper.getById(yearsStandardVo.getPlanYearId());
|
|
|
- //BigDecimal evaluation = byId.getEvaluation();
|
|
|
- //BigDecimal threshold = new BigDecimal(0);
|
|
|
- ////获取各个项目类型设定的概算金额阈值
|
|
|
- //List<SysDictData> data = dictTypeService.selectDictDataByType("sys_over_limit_threshold");
|
|
|
- //HashMap<String, String> thresholdMap = new LinkedHashMap<>();
|
|
|
- ////各个类型的概算金额阈值
|
|
|
- //for (SysDictData dictData : data) {
|
|
|
- // // 类型----阈值
|
|
|
- // thresholdMap.put(dictData.getDictLabel(), dictData.getDictValue());
|
|
|
- //}
|
|
|
- ////项目类型
|
|
|
- //for (ProjectTypes value : ProjectTypes.values()) {
|
|
|
- // if (byId.getProjectType().equals(value.getCode())) {
|
|
|
- // threshold = BigDecimal.valueOf(Long.parseLong(thresholdMap.get(value.getInfo())));
|
|
|
- // }
|
|
|
- // break;
|
|
|
- //}
|
|
|
- //
|
|
|
- //if (evaluation.compareTo(threshold) == 1) {
|
|
|
- // //是超额项目
|
|
|
- //}
|
|
|
|
|
|
int commit = planYearsMapper.commit(yearsStandardVo.getPlanYearId());
|
|
|
if (commit != 1) {
|
|
@@ -435,7 +468,6 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
@Transactional
|
|
|
public AjaxResult reviewTo(PlanYearsStandardVo vo) {
|
|
|
//年度计划审核通过后同步到季度计划和项目管理
|
|
|
- PlanYears ofYears = new PlanYears();
|
|
|
PlanQuarter quarters = new PlanQuarter();
|
|
|
PmDemand demand = new PmDemand();
|
|
|
PlanYears byId = planYearsMapper.getById(vo.getPlanYearId());
|
|
@@ -457,12 +489,20 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
demand.setPurchaseDeptId(Long.valueOf(byId.getPurchaseDeptId()));
|
|
|
demand.setCreateTime(new Date());
|
|
|
pmDemandMapper.insert(demand);
|
|
|
- //计划附件也进行同步---查询年度计划附件后复制一份改为项目需求附件
|
|
|
+ log.info("预警状态更新:demandID:{}", demand.getDemandId());
|
|
|
+ demandService.updateDemandWarnStatus(demand.getDemandId());
|
|
|
+ //计划附件进行同步---查询年度计划附件后分别添加项目需求附件和季度附件
|
|
|
LambdaQueryWrapper<SysFileRef> sysFileRefLp = new LambdaQueryWrapper<>();
|
|
|
sysFileRefLp.eq(SysFileRef::getType, SysFileRefEnum.PLAN_YEAR.getType());
|
|
|
sysFileRefLp.eq(SysFileRef::getRedId, vo.getPlanYearId());
|
|
|
List<SysFileRef> sysFileRefs = sysFileRefMapper.selectList(sysFileRefLp);
|
|
|
if (!ObjectUtils.isEmpty(sysFileRefs)) {
|
|
|
+ for (SysFileRef ref : sysFileRefs) {
|
|
|
+ ref.setRedId(quarters.getPlanPracticalId());
|
|
|
+ ref.setType(SysFileRefEnum.PLAN_TEMPORARY.getType());
|
|
|
+ ref.setId(null);
|
|
|
+ sysFileRefMapper.insert(ref);
|
|
|
+ }
|
|
|
for (SysFileRef ref : sysFileRefs) {
|
|
|
ref.setRedId(demand.getDemandId());
|
|
|
ref.setType(SysFileRefEnum.PM_DEMAND.getType());
|
|
@@ -553,6 +593,13 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
SysDept sysDept = deptMapper.selectDeptById(sysUser.getDeptId());
|
|
|
QueryWrapper<PlanYears> queryWrapper = new QueryWrapper<>();
|
|
|
queryWrapper.eq("purchase_dept_id", sysDept.getDeptId());
|
|
|
+ queryWrapper.eq("delFlay", DataIsDelete.DataNOTDelete.getCode());
|
|
|
+ planYears = planYearsMapper.selectList(queryWrapper);
|
|
|
+ }
|
|
|
+ List<SysRole> sysRoleList2 = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("admin")).collect(Collectors.toList());
|
|
|
+ if (sysRoleList2.size() > 0) {
|
|
|
+ QueryWrapper<PlanYears> queryWrapper = new QueryWrapper<>();
|
|
|
+ queryWrapper.eq("delFlay", DataIsDelete.DataNOTDelete.getCode());
|
|
|
planYears = planYearsMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
@@ -566,24 +613,21 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
List<PlanYears> planYears = new ArrayList<>();
|
|
|
try {
|
|
|
List<SysRole> sysRoles = sysRoleMapper.selectRolePermissionByUserId(SecurityUtils.getUserId());
|
|
|
- List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("demand_unit")).collect(Collectors.toList());
|
|
|
+ List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("purchasing_management")).collect(Collectors.toList());
|
|
|
if (sysRoleList.size() > 0) {
|
|
|
SysUser sysUser = userService.selectUserById(SecurityUtils.getUserId());
|
|
|
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) {
|
|
|
- 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()))
|
|
|
- .or(wrapper -> wrapper.lambda().in(PlanYears::getPurchaseDeptId, collect)
|
|
|
- .eq(PlanYears::getIsExcess, IsExcess.EXCESS.getCode()))
|
|
|
+ queryWrapper.eq("purchaseDeptId", sysDept.getDeptId())
|
|
|
.in("project_status", ProjectStatus.PLANWAIEXAMINE.getCode(), ProjectStatus.PLANTOEXAMINE.getCode());
|
|
|
planYears = planYearsMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
+ List<SysRole> sysRoleList2 = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("admin")).collect(Collectors.toList());
|
|
|
+ if (sysRoleList2.size() > 0) {
|
|
|
+ QueryWrapper<PlanYears> queryWrapper = new QueryWrapper<>();
|
|
|
+ queryWrapper.in("project_status", ProjectStatus.PLANWAIEXAMINE.getCode(), ProjectStatus.PLANTOEXAMINE.getCode());
|
|
|
+ planYears = planYearsMapper.selectList(queryWrapper);
|
|
|
+ }
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -595,7 +639,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
List<PmDemand> pmDemands = new ArrayList<>();
|
|
|
try {
|
|
|
List<SysRole> sysRoles = sysRoleMapper.selectRolePermissionByUserId(SecurityUtils.getUserId());
|
|
|
- List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("purchasing_management")).collect(Collectors.toList());
|
|
|
+ List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("demand_unit")).collect(Collectors.toList());
|
|
|
if (sysRoleList.size() > 0) {
|
|
|
SysUser sysUser = userService.selectUserById(SecurityUtils.getUserId());
|
|
|
SysDept sysDept = deptMapper.selectDeptById(sysUser.getDeptId());
|
|
@@ -603,6 +647,11 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
queryWrapper.eq("purchase_dept_id", sysDept.getDeptId());
|
|
|
pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
+ List<SysRole> sysRoleList2 = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("admin")).collect(Collectors.toList());
|
|
|
+ if (sysRoleList2.size() > 0) {
|
|
|
+ QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
|
+ pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
+ }
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -614,24 +663,22 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
List<PmDemand> pmDemands = new ArrayList<>();
|
|
|
try {
|
|
|
List<SysRole> sysRoles = sysRoleMapper.selectRolePermissionByUserId(SecurityUtils.getUserId());
|
|
|
- List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("demand_unit")).collect(Collectors.toList());
|
|
|
+ List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("purchasing_management")).collect(Collectors.toList());
|
|
|
if (sysRoleList.size() > 0) {
|
|
|
SysUser sysUser = userService.selectUserById(SecurityUtils.getUserId());
|
|
|
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) {
|
|
|
- collect.add(-1L);
|
|
|
- }
|
|
|
QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
|
- queryWrapper
|
|
|
- .or(wrapper -> wrapper.lambda().eq(PmDemand::getPurchaseDeptId, sysDept.getDeptId())
|
|
|
- .eq(PmDemand::getIsExcess, IsExcess.NO_EXCESS.getCode()))
|
|
|
- .or(wrapper -> wrapper.lambda().in(PmDemand::getPurchaseDeptId, collect)
|
|
|
- .eq(PmDemand::getIsExcess, IsExcess.EXCESS.getCode()))
|
|
|
+ queryWrapper.eq("purchaseDeptId", sysDept.getDeptId())
|
|
|
.in("project_status", PmProjectStatus.DEMAND_WAIT_AUDIT.getCode(), PmProjectStatus.DEMAND_AUDIT_RETURN.getCode());
|
|
|
pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
+ List<SysRole> sysRoleList2 = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("admin")).collect(Collectors.toList());
|
|
|
+ if (sysRoleList2.size() > 0) {
|
|
|
+ QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
|
+ queryWrapper.in("project_status", PmProjectStatus.DEMAND_WAIT_AUDIT.getCode(), PmProjectStatus.DEMAND_AUDIT_RETURN.getCode());
|
|
|
+ pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
+ }
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -643,7 +690,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
List<PmDemand> pmDemands = new ArrayList<>();
|
|
|
try {
|
|
|
List<SysRole> sysRoles = sysRoleMapper.selectRolePermissionByUserId(SecurityUtils.getUserId());
|
|
|
- List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("purchasing_management")).collect(Collectors.toList());
|
|
|
+ List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("demand_unit")).collect(Collectors.toList());
|
|
|
if (sysRoleList.size() > 0) {
|
|
|
SysUser sysUser = userService.selectUserById(SecurityUtils.getUserId());
|
|
|
SysDept sysDept = deptMapper.selectDeptById(sysUser.getDeptId());
|
|
@@ -652,6 +699,12 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
queryWrapper.in("project_status", PmProjectStatus.CONTRACT_WAIT_FILL.getCode(), PmProjectStatus.UNDER_CONSTRUCTION.getCode());
|
|
|
pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
+ List<SysRole> sysRoleList2 = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("admin")).collect(Collectors.toList());
|
|
|
+ if (sysRoleList2.size() > 0) {
|
|
|
+ QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
|
+ queryWrapper.in("project_status", PmProjectStatus.CONTRACT_WAIT_FILL.getCode(), PmProjectStatus.UNDER_CONSTRUCTION.getCode());
|
|
|
+ pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
+ }
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -663,7 +716,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
List<PmDemand> pmDemands = new ArrayList<>();
|
|
|
try {
|
|
|
List<SysRole> sysRoles = sysRoleMapper.selectRolePermissionByUserId(SecurityUtils.getUserId());
|
|
|
- List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("purchasing_management")).collect(Collectors.toList());
|
|
|
+ List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("demand_unit")).collect(Collectors.toList());
|
|
|
if (sysRoleList.size() > 0) {
|
|
|
SysUser sysUser = userService.selectUserById(SecurityUtils.getUserId());
|
|
|
SysDept sysDept = deptMapper.selectDeptById(sysUser.getDeptId());
|
|
@@ -672,6 +725,12 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
queryWrapper.in("project_status", PmProjectStatus.UNDER_CONSTRUCTION.getCode(), PmProjectStatus.COMPLETION_CONSTRUCTION.getCode());
|
|
|
pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
+ List<SysRole> sysRoleList2 = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("admin")).collect(Collectors.toList());
|
|
|
+ if (sysRoleList2.size() > 0) {
|
|
|
+ QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
|
+ queryWrapper.in("project_status", PmProjectStatus.UNDER_CONSTRUCTION.getCode(), PmProjectStatus.COMPLETION_CONSTRUCTION.getCode());
|
|
|
+ pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
+ }
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -683,21 +742,12 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
List<PmDemand> pmDemands = new ArrayList<>();
|
|
|
try {
|
|
|
List<SysRole> sysRoles = sysRoleMapper.selectRolePermissionByUserId(SecurityUtils.getUserId());
|
|
|
- List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("demand_unit")).collect(Collectors.toList());
|
|
|
+ List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("purchasing_management")).collect(Collectors.toList());
|
|
|
if (sysRoleList.size() > 0) {
|
|
|
SysUser sysUser = userService.selectUserById(SecurityUtils.getUserId());
|
|
|
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) {
|
|
|
- collect.add(-1L);
|
|
|
- }
|
|
|
QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
|
- queryWrapper
|
|
|
- .or(wrapper -> wrapper.lambda().eq(PmDemand::getPurchaseDeptId, sysDept.getDeptId())
|
|
|
- .eq(PmDemand::getIsExcess, IsExcess.NO_EXCESS.getCode()))
|
|
|
- .or(wrapper -> wrapper.lambda().in(PmDemand::getPurchaseDeptId, collect)
|
|
|
- .eq(PmDemand::getIsExcess, IsExcess.EXCESS.getCode()))
|
|
|
+ queryWrapper.eq("purchase_dept_id", sysDept.getDeptId())
|
|
|
.in("project_status", PmProjectStatus.TASK_WAIT_RELEASE.getCode(),
|
|
|
PmProjectStatus.WAIT_SELECT_AGENT.getCode(),
|
|
|
PmProjectStatus.WAIT_UPLOAD_BID_FILE.getCode(),
|
|
@@ -708,6 +758,18 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
);
|
|
|
pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
+ List<SysRole> sysRoleList2 = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("admin")).collect(Collectors.toList());
|
|
|
+ if (sysRoleList2.size() > 0) {
|
|
|
+ QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
|
+ queryWrapper.in("project_status", PmProjectStatus.TASK_WAIT_RELEASE.getCode(),
|
|
|
+ PmProjectStatus.WAIT_SELECT_AGENT.getCode(),
|
|
|
+ PmProjectStatus.WAIT_UPLOAD_BID_FILE.getCode(),
|
|
|
+ PmProjectStatus.WAIT_ANNOUNCEMENT.getCode(),
|
|
|
+ PmProjectStatus.WAIT_OPEN_BID.getCode(),
|
|
|
+ PmProjectStatus.WAIT_BID_ANNOUNCEMENT.getCode(),
|
|
|
+ PmProjectStatus.BIDDING_PUBLICITY.getCode());
|
|
|
+ pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
+ }
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -719,21 +781,12 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
List<PmDemand> pmDemands = new ArrayList<>();
|
|
|
try {
|
|
|
List<SysRole> sysRoles = sysRoleMapper.selectRolePermissionByUserId(SecurityUtils.getUserId());
|
|
|
- List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("demand_unit")).collect(Collectors.toList());
|
|
|
+ List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("procurement_office")).collect(Collectors.toList());
|
|
|
if (sysRoleList.size() > 0) {
|
|
|
SysUser sysUser = userService.selectUserById(SecurityUtils.getUserId());
|
|
|
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) {
|
|
|
- collect.add(-1L);
|
|
|
- }
|
|
|
QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
|
- queryWrapper
|
|
|
- .or(wrapper -> wrapper.lambda().eq(PmDemand::getPurchaseDeptId, sysDept.getDeptId())
|
|
|
- .eq(PmDemand::getIsExcess, IsExcess.NO_EXCESS.getCode()))
|
|
|
- .or(wrapper -> wrapper.lambda().in(PmDemand::getPurchaseDeptId, collect)
|
|
|
- .eq(PmDemand::getIsExcess, IsExcess.EXCESS.getCode()))
|
|
|
+ queryWrapper.eq("purchase_dept_id", sysDept.getDeptId())
|
|
|
.in("project_status",
|
|
|
PmProjectStatus.WAIT_SELECT_AGENT.getCode(),
|
|
|
PmProjectStatus.WAIT_UPLOAD_BID_FILE.getCode(),
|
|
@@ -744,6 +797,18 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
PmProjectStatus.CONTRACT_WAIT_FILL.getCode());
|
|
|
pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
+ List<SysRole> sysRoleList2 = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("admin")).collect(Collectors.toList());
|
|
|
+ if (sysRoleList2.size() > 0) {
|
|
|
+ QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
|
+ queryWrapper.in("project_status", PmProjectStatus.WAIT_SELECT_AGENT.getCode(),
|
|
|
+ PmProjectStatus.WAIT_UPLOAD_BID_FILE.getCode(),
|
|
|
+ PmProjectStatus.WAIT_ANNOUNCEMENT.getCode(),
|
|
|
+ PmProjectStatus.WAIT_OPEN_BID.getCode(),
|
|
|
+ PmProjectStatus.WAIT_BID_ANNOUNCEMENT.getCode(),
|
|
|
+ PmProjectStatus.BIDDING_PUBLICITY.getCode(),
|
|
|
+ PmProjectStatus.CONTRACT_WAIT_FILL.getCode());
|
|
|
+ pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
+ }
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -755,24 +820,21 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
List<PmDemand> pmDemands = new ArrayList<>();
|
|
|
try {
|
|
|
List<SysRole> sysRoles = sysRoleMapper.selectRolePermissionByUserId(SecurityUtils.getUserId());
|
|
|
- List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("demand_unit")).collect(Collectors.toList());
|
|
|
+ List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("procurement_office")).collect(Collectors.toList());
|
|
|
if (sysRoleList.size() > 0) {
|
|
|
SysUser sysUser = userService.selectUserById(SecurityUtils.getUserId());
|
|
|
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) {
|
|
|
- collect.add(-1L);
|
|
|
- }
|
|
|
QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
|
- queryWrapper
|
|
|
- .or(wrapper -> wrapper.lambda().eq(PmDemand::getPurchaseDeptId, sysDept.getDeptId())
|
|
|
- .eq(PmDemand::getIsExcess, IsExcess.NO_EXCESS.getCode()))
|
|
|
- .or(wrapper -> wrapper.lambda().in(PmDemand::getPurchaseDeptId, collect)
|
|
|
- .eq(PmDemand::getIsExcess, IsExcess.EXCESS.getCode()))
|
|
|
+ queryWrapper.eq("purchase_dept_id", sysDept.getDeptId())
|
|
|
.lt("project_status", PmProjectStatus.CONTRACT_WAIT_FILL.getCode());
|
|
|
pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
+ List<SysRole> sysRoleList2 = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("admin")).collect(Collectors.toList());
|
|
|
+ if (sysRoleList2.size() > 0) {
|
|
|
+ QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
|
+ queryWrapper.lt("project_status", PmProjectStatus.CONTRACT_WAIT_FILL.getCode());
|
|
|
+ pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
+ }
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -784,24 +846,21 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
List<PmDemand> pmDemands = new ArrayList<>();
|
|
|
try {
|
|
|
List<SysRole> sysRoles = sysRoleMapper.selectRolePermissionByUserId(SecurityUtils.getUserId());
|
|
|
- List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("demand_unit")).collect(Collectors.toList());
|
|
|
+ List<SysRole> sysRoleList = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("procurement_office")).collect(Collectors.toList());
|
|
|
if (sysRoleList.size() > 0) {
|
|
|
SysUser sysUser = userService.selectUserById(SecurityUtils.getUserId());
|
|
|
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) {
|
|
|
- collect.add(-1L);
|
|
|
- }
|
|
|
QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
|
- queryWrapper
|
|
|
- .or(wrapper -> wrapper.lambda().eq(PmDemand::getPurchaseDeptId, sysDept.getDeptId())
|
|
|
- .eq(PmDemand::getIsExcess, IsExcess.NO_EXCESS.getCode()))
|
|
|
- .or(wrapper -> wrapper.lambda().in(PmDemand::getPurchaseDeptId, collect)
|
|
|
- .eq(PmDemand::getIsExcess, IsExcess.EXCESS.getCode()))
|
|
|
+ queryWrapper.eq("purchase_dept_id", sysDept.getDeptId())
|
|
|
.gt("project_status", PmProjectStatus.CONTRACT_WAIT_FILL.getCode());
|
|
|
pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
}
|
|
|
+ List<SysRole> sysRoleList2 = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals("admin")).collect(Collectors.toList());
|
|
|
+ if (sysRoleList2.size() > 0) {
|
|
|
+ QueryWrapper<PmDemand> queryWrapper = new QueryWrapper<>();
|
|
|
+ queryWrapper.gt("project_status", PmProjectStatus.CONTRACT_WAIT_FILL.getCode());
|
|
|
+ pmDemands = pmDemandMapper.selectList(queryWrapper);
|
|
|
+ }
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -850,6 +909,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
if (!ObjectUtils.isEmpty(demandRes) && demandRes.size() > 0) {
|
|
|
for (PmDemandResVo demandResVo : demandRes) {
|
|
|
HomeToDoQueryResVo home = new HomeToDoQueryResVo();
|
|
|
+ home.setEvaluation(BigDecimal.valueOf(demandResVo.getEvaluation()));
|
|
|
BeanUtils.copyProperties(demandResVo, home);
|
|
|
homeRes.add(home);
|
|
|
}
|
|
@@ -876,6 +936,7 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
if (!ObjectUtils.isEmpty(demandRes) && demandRes.size() > 0) {
|
|
|
for (PmDemandResVo demandResVo : demandRes) {
|
|
|
HomeToDoQueryResVo home = new HomeToDoQueryResVo();
|
|
|
+ home.setEvaluation(BigDecimal.valueOf(demandResVo.getEvaluation()));
|
|
|
BeanUtils.copyProperties(demandResVo, home);
|
|
|
homeRes.add(home);
|
|
|
}
|
|
@@ -1206,32 +1267,6 @@ public class PlanYearsServiceImpl extends ServiceImpl<PlanYearsMapper, PlanYears
|
|
|
return quarterRes;
|
|
|
}
|
|
|
|
|
|
- //判断是否为超额计划
|
|
|
- public String isExcessOrNo(String projectType, BigDecimal evaluation) {
|
|
|
- BigDecimal threshold = new BigDecimal(0);
|
|
|
- //获取各个项目类型设定的概算金额阈值
|
|
|
- List<SysDictData> data = dictTypeService.selectDictDataByType("sys_over_limit_threshold");
|
|
|
- HashMap<String, String> thresholdMap = new LinkedHashMap<>();
|
|
|
- //各个类型的概算金额阈值
|
|
|
- for (SysDictData dictData : data) {
|
|
|
- // 类型----阈值
|
|
|
- thresholdMap.put(dictData.getDictLabel(), dictData.getDictValue());
|
|
|
- }
|
|
|
- //项目类型
|
|
|
- for (ProjectTypes value : ProjectTypes.values()) {
|
|
|
- if (projectType.equals(value.getCode())) {
|
|
|
- threshold = BigDecimal.valueOf(Long.parseLong(thresholdMap.get(value.getInfo())));
|
|
|
- }
|
|
|
- break;
|
|
|
- }
|
|
|
- if (evaluation.compareTo(threshold) == 1) {
|
|
|
- //是超额计划
|
|
|
- return ("1");
|
|
|
- } else {
|
|
|
- return ("0");
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
//字段赋值对应的名称
|
|
|
public List<PlanYearsResponseVo> changeTo(List<PlanYears> planYears) {
|
|
|
//获取年度计划提报时间的阈值
|