| | |
| | | import java.time.LocalDateTime; |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | import java.util.Objects; |
| | | import java.util.stream.Collectors; |
| | | |
| | | |
| | |
| | | if (queryParam.getExperimentId() != null) { |
| | | predicateList.add(criteriaBuilder.equal(root.get("experimentId"), queryParam.getExperimentId())); |
| | | } |
| | | Join<RiskAssessPlan, RiskAssessPlanIdentificationUser> identificationUserJoin = root.join("riskAssessPlanIdentificationUsers", JoinType.LEFT); |
| | | Join<RiskAssessPlan, RiskAssessPlanEvaluateUser> evaluateUserJoin = root.join("riskAssessPlanEvaluateUsers", JoinType.LEFT); |
| | | // Join<RiskAssessPlan, RiskAssessPlanIdentificationUser> identificationUserJoin = root.join("riskAssessPlanIdentificationUsers", JoinType.LEFT); |
| | | // Join<RiskAssessPlan, RiskAssessPlanEvaluateUser> evaluateUserJoin = root.join("riskAssessPlanEvaluateUsers", JoinType.LEFT); |
| | | Join<RiskAssessPlan, RiskAssessPlanIdentificationUser> identificationJoin = |
| | | root.join("riskAssessPlanIdentificationUsers", JoinType.LEFT); |
| | | identificationJoin.on(criteriaBuilder.equal(identificationJoin.get("deleteStatus"), StatusEnum.DELETE_NOT.getCode())); |
| | | |
| | | // LEFT JOIN riskAssessPlanEvaluateUsers |
| | | Join<RiskAssessPlan, RiskAssessPlanEvaluateUser> evaluateJoin = |
| | | root.join("riskAssessPlanEvaluateUsers", JoinType.LEFT); |
| | | evaluateJoin.on(criteriaBuilder.equal(evaluateJoin.get("deleteStatus"), StatusEnum.DELETE_NOT.getCode())); |
| | | |
| | | |
| | | if (roleTag == UserTagEnum.USER_TAG_0.getCode()) { |
| | | predicateList.add(criteriaBuilder.equal(root.get("planUserId"), currentUserId)); |
| | |
| | | // ) |
| | | // ); |
| | | } |
| | | |
| | | query.groupBy(root.get("id")); |
| | | predicateList.add(criteriaBuilder.equal(root.get("deleteStatus"), StatusEnum.DELETE_NOT.getCode())); |
| | | return criteriaBuilder.and(predicateList.toArray(new Predicate[0])); |
| | |
| | | |
| | | PageRequest pageParam = PageRequest.of(queryParam.getPageIndex() - 1, queryParam.getPageSize(), Sort.Direction.DESC, "updateTime"); |
| | | Page<RiskAssessPlan> pageResult = assessPlanRepository.findAll(specification, pageParam); |
| | | |
| | | |
| | | |
| | | Long countDynamic = assessPlanRepository.countDynamic(queryParam.getAssessPlanName(), queryParam.getExperimentId(), roleTag == UserTagEnum.USER_TAG_0.getCode() ? currentUserId : null, queryParam.getRiskUnitIds()); |
| | | |
| | | |
| | | List<RiskAssessPlanQueryDTO> assessPlanQueryDTOS = BeanCopyUtils.copyBeanList(pageResult.getContent(), RiskAssessPlanQueryDTO.class); |
| | | |
| | |
| | | } |
| | | |
| | | searchResult.setData(assessPlanQueryDTOS); |
| | | searchResult.setTotal(pageResult.getTotalElements()); |
| | | searchResult.setTotal(countDynamic); |
| | | return searchResult; |
| | | } |
| | | |
| | |
| | | if (assessPlanById.getPlanSellStatus() == 1) { |
| | | throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR.getCode(), "该计划尚未派发,无法辨识"); |
| | | } |
| | | if (assessPlanById.getPlanExecStatus() != 2) { |
| | | throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR.getCode(), "该计划不处在辨识阶段,无法辨识"); |
| | | } |
| | | //20250520修改评价阶段也可以进行新增辨识 |
| | | // if (assessPlanById.getPlanExecStatus() != 2) { |
| | | // throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR.getCode(), "该计划不处在辨识阶段,无法辨识"); |
| | | // } |
| | | if (date.isAfter(assessPlanById.getAssessEndTime())) { |
| | | throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR.getCode(), "风险辨识必须在评估结束时间之前"); |
| | | } |
| | |
| | | } |
| | | if (planIds.size() > 0) { |
| | | predicateList.add(criteriaBuilder.in(root.get("id")).value(planIds)); |
| | | queryParam.setPlanIds(planIds); |
| | | } |
| | | |
| | | Join<RiskAssessPlan, RiskAssessPlanIdentificationUser> identificationUserJoin = root.join("riskAssessPlanIdentificationUsers", JoinType.LEFT); |
| | |
| | | |
| | | |
| | | if (roleTag == UserTagEnum.USER_TAG_0.getCode()) { |
| | | queryParam.setUserTag(UserTagEnum.USER_TAG_0.getCode().byteValue()); |
| | | queryParam.setUserId(currentUserId); |
| | | //辨识 |
| | | if (queryParam.getTag() == 1) { |
| | | predicateList.add(criteriaBuilder.equal(identificationUserJoin.get("identificationUserId"), currentUserId)); |
| | |
| | | |
| | | PageRequest pageParam = PageRequest.of(queryParam.getPageIndex() - 1, queryParam.getPageSize(), Sort.Direction.DESC, "updateTime"); |
| | | Page<RiskAssessPlan> pageResult = assessPlanRepository.findAll(specification, pageParam); |
| | | long pageCount = riskPlanDataMapper.getPageCount(queryParam); |
| | | |
| | | |
| | | //循环遍历结果集,封装查询结果 |
| | | List<AssessQueryDTO> assessQueryDTOList = new ArrayList<>(); |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(pha.getUpdateTime()); |
| | | for (LecQueryDTO lec : lecList) { |
| | | if (lec.getIdentificationId() == pha.getId()) { |
| | | if (Objects.equals(lec.getIdentificationId(), pha.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.lecMatchPha(pha, lec); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(jha.getUpdateTime()); |
| | | for (LecQueryDTO lec : lecList) { |
| | | if (lec.getIdentificationId() == jha.getId()) { |
| | | if (Objects.equals(lec.getIdentificationId(), jha.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.lecMatchJha(jha, lec); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(scl.getUpdateTime()); |
| | | for (LecQueryDTO lec : lecList) { |
| | | if (lec.getIdentificationId() == scl.getId()) { |
| | | if (Objects.equals(lec.getIdentificationId(), scl.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.lecMatchScl(scl, lec); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(hazop.getUpdateTime()); |
| | | for (LecQueryDTO lec : lecList) { |
| | | if (lec.getIdentificationId() == hazop.getId()) { |
| | | if (Objects.equals(lec.getIdentificationId(), hazop.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.lecMatchHazop(hazop, lec); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(analogy.getUpdateTime()); |
| | | for (LecQueryDTO lec : lecList) { |
| | | if (lec.getIdentificationId() == analogy.getId()) { |
| | | if (Objects.equals(lec.getIdentificationId(), analogy.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.lecMatchAnalogy(analogy, lec); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(pha.getUpdateTime()); |
| | | for (LsQueryDTO ls : lsList) { |
| | | if (ls.getIdentificationId() == pha.getId()) { |
| | | if (Objects.equals(ls.getIdentificationId(), pha.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.lsMatchPha(pha, ls); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(jha.getUpdateTime()); |
| | | for (LsQueryDTO ls : lsList) { |
| | | if (ls.getIdentificationId() == jha.getId()) { |
| | | if (Objects.equals(ls.getIdentificationId(), jha.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.lsMatchJha(jha, ls); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(scl.getUpdateTime()); |
| | | for (LsQueryDTO ls : lsList) { |
| | | if (ls.getIdentificationId() == scl.getId()) { |
| | | if (Objects.equals(ls.getIdentificationId(), scl.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.lsMatchScl(scl, ls); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(hazop.getUpdateTime()); |
| | | for (LsQueryDTO ls : lsList) { |
| | | if (ls.getIdentificationId() == hazop.getId()) { |
| | | if (Objects.equals(ls.getIdentificationId(), hazop.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.lsMatchHazop(hazop, ls); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(analogy.getUpdateTime()); |
| | | for (LsQueryDTO ls : lsList) { |
| | | if (ls.getIdentificationId() == analogy.getId()) { |
| | | if (Objects.equals(ls.getIdentificationId(), analogy.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.lsMatchAnalogy(analogy, ls); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(pha.getUpdateTime()); |
| | | for (MesQueryDTO mes : mesList) { |
| | | if (mes.getIdentificationId() == pha.getId()) { |
| | | if (Objects.equals(mes.getIdentificationId(), pha.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.mesMatchPha(pha, mes); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(jha.getUpdateTime()); |
| | | for (MesQueryDTO mes : mesList) { |
| | | if (mes.getIdentificationId() == jha.getId()) { |
| | | if (Objects.equals(mes.getIdentificationId(), jha.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.mesMatchJha(jha, mes); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(scl.getUpdateTime()); |
| | | for (MesQueryDTO mes : mesList) { |
| | | if (mes.getIdentificationId() == scl.getId()) { |
| | | if (Objects.equals(mes.getIdentificationId(), scl.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.mesMatchScl(scl, mes); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(pha.getUpdateTime()); |
| | | for (RsQueryDTO rs : rsList) { |
| | | if (rs.getIdentificationId() == pha.getId()) { |
| | | if (Objects.equals(rs.getIdentificationId(), pha.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.rsMatchPha(pha, rs); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(jha.getUpdateTime()); |
| | | for (RsQueryDTO rs : rsList) { |
| | | if (rs.getIdentificationId() == jha.getId()) { |
| | | if (Objects.equals(rs.getIdentificationId(), jha.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.rsMatchJha(jha, rs); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(scl.getUpdateTime()); |
| | | for (RsQueryDTO rs : rsList) { |
| | | if (rs.getIdentificationId() == scl.getId()) { |
| | | if (Objects.equals(rs.getIdentificationId(), scl.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.rsMatchScl(scl, rs); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(hazop.getUpdateTime()); |
| | | for (RsQueryDTO rs : rsList) { |
| | | if (rs.getIdentificationId() == hazop.getId()) { |
| | | if (Objects.equals(rs.getIdentificationId(), hazop.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.rsMatchHazop(hazop, rs); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | | factorQueryDTO.setItemIdentificationTime(analogy.getUpdateTime()); |
| | | for (RsQueryDTO rs : rsList) { |
| | | if (rs.getIdentificationId() == analogy.getId()) { |
| | | if (Objects.equals(rs.getIdentificationId(), analogy.getId())) { |
| | | EvaluateAndIdentificationUtils evaluateAndIdentificationUtils = new EvaluateAndIdentificationUtils(); |
| | | factorQueryDTO = evaluateAndIdentificationUtils.rsMatchAnalogy(analogy, rs); |
| | | factorQueryDTO.setEvaluateMethod(riskAssessPlan.getEvaluateMethod()); |
| | |
| | | } |
| | | } |
| | | for (UserInfoDomainDTO user : userList) { |
| | | if (user.getId() == assessQueryDTO.getCreateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getCreateByUserId())) { |
| | | assessQueryDTO.setCreateByUserName(user.getRealName()); |
| | | } |
| | | if (user.getId() == assessQueryDTO.getUpdateByUserId()) { |
| | | if (Objects.equals(user.getId(), assessQueryDTO.getUpdateByUserId())) { |
| | | assessQueryDTO.setUpdateByUserName(user.getRealName()); |
| | | } |
| | | } |
| | |
| | | } |
| | | |
| | | searchResult.setData(assessQueryDTOList); |
| | | searchResult.setTotal(pageResult.getTotalElements()); |
| | | searchResult.setTotal(pageCount); |
| | | searchResult.setCount(assessQueryDTOList.size()); |
| | | return searchResult; |
| | | } |