| | |
| | | @Resource |
| | | ZfDoctorShareService zfDoctorShareService; |
| | | |
| | | @Resource |
| | | ZfDoctorDownloadService zfDoctorDownloadService; |
| | | |
| | | |
| | | @Override |
| | | public AjaxResult selectDoctorList(ZfDoctor zfDoctor, Integer pageNum, Integer pageSize) { |
| | |
| | | return AjaxResult.success("您没加入到对应的家庭,请联系管理员"); |
| | | } |
| | | Long familyId = myself.getFamilyId(); |
| | | |
| | | //查看父母的数据: |
| | | Long fatherFaId = 0L; |
| | | if(myself.getFatherId()!=null) |
| | | fatherFaId = zInfoUserService.getInfoById(myself.getFatherId()).getFamilyId(); |
| | | Long motherFaId = 0L; |
| | | if(myself.getMomId()!=null) |
| | | motherFaId = zInfoUserService.getInfoById(myself.getMomId()).getFamilyId(); |
| | | |
| | | //也要查别人授权的 |
| | | List<ZAuthority> authority = zAuthorityService.getAuthority(); |
| | | List<Long> idList = authority.stream().filter(auth -> auth.getAuthority().toString().equals(DOCTOR_LIST)).map(ZAuthority::getFid).collect(Collectors.toList()); |
| | | //加上自己家庭的id |
| | | idList.add(familyId); |
| | | |
| | | //加上父母家族id |
| | | idList.add(fatherFaId); |
| | | idList.add(motherFaId); |
| | | |
| | | // String familyIds = listFamilyIds(); |
| | | // String secondFamilyAuthority = listSecondFamilyIds(); |
| | | |
| | | //查看别人分享 |
| | | List<ZfDoctor> bs = zfDoctorShareService.listUserId(myself.getUserId()); |
| | | |
| | | // String secondFamilyAuthority = listSecondFamilyIds() |
| | | LambdaQueryWrapper<ZfDoctor> lqw = buildCondition(zfDoctor, idList); |
| | | |
| | | Page<ZfDoctor> zfDoctorPage = new Page<>(pageNum, pageSize); |
| | |
| | | |
| | | List<ZfDoctor> beanRecords = pageResult.getRecords();//得到查询出来的数据 |
| | | |
| | | List<ZfDoctor> dtoResult = markOwnData(familyId, beanRecords); |
| | | dtoResult.addAll(bs); |
| | | List<ZfDoctor> dtoResult = markOwnData(familyId,fatherFaId, motherFaId, beanRecords); |
| | | HashMap<String, Object> data = MapUtils.getResult(pageResult, dtoResult); |
| | | return AjaxResult.success(data); |
| | | } |
| | |
| | | //要查自己家庭的 |
| | | ZInfoUser myself = zInfoUserService.getMyself(); |
| | | Long familyId = myself.getFamilyId(); |
| | | |
| | | //查看父母的数据: |
| | | Long fatherFaId = 0L; |
| | | if(myself.getFatherId()!=null) |
| | | fatherFaId = zInfoUserService.getInfoById(myself.getFatherId()).getFamilyId(); |
| | | Long motherFaId = 0L; |
| | | if(myself.getMomId()!=null) |
| | | motherFaId = zInfoUserService.getInfoBysysId(myself.getMomId()).getFamilyId(); |
| | | |
| | | //也要查别人授权的 |
| | | List<ZAuthority> authority = zAuthorityService.getAuthority(); |
| | | List<Long> idList = authority.stream().filter(auth -> auth.getAuthority().toString().equals(DOCTOR_LIST)).map(ZAuthority::getFid).collect(Collectors.toList()); |
| | | //加上自己家庭的id |
| | | idList.add(familyId); |
| | | |
| | | //查看别人分享 |
| | | List<ZfDoctor> bs = zfDoctorShareService.listUserId(myself.getUserId()); |
| | | //加上父母家族id |
| | | idList.add(fatherFaId); |
| | | idList.add(motherFaId); |
| | | |
| | | |
| | | LambdaQueryWrapper<ZfDoctor> lambdaQueryWrapper = buildCondition(zfDoctor, idList); |
| | | List<ZfDoctor> beanRecords = list(lambdaQueryWrapper); |
| | | beanRecords.addAll(bs); |
| | | log.info("从数据库中查到的为:{}", beanRecords); |
| | | return markOwnData(familyId, beanRecords); |
| | | return markOwnData(familyId, fatherFaId, motherFaId,beanRecords); |
| | | } |
| | | |
| | | public List<ZfDoctor> markOwnData(Long familyId, List<ZfDoctor> beanRecords) { |
| | | public List<ZfDoctor> markOwnData(Long familyId,Long fatherFamilyId, Long motherFamilyId, List<ZfDoctor> beanRecords) { |
| | | return beanRecords.stream().peek( |
| | | bean -> { |
| | | if (bean.getFamilyId() == familyId) { |
| | | if (bean.getFamilyId() == familyId||(fatherFamilyId!=0L && fatherFamilyId==familyId)||(motherFamilyId!=0L && motherFamilyId==familyId)) { |
| | | bean.setOwnData(1); |
| | | } else { |
| | | bean.setOwnData(0); |
| | |
| | | |
| | | |
| | | for (ZfDoctor zfDoctor : dataList) { |
| | | if (zfDoctor.getSymptom().length() == 0 || zfDoctor.getSymptom() == null) { |
| | | throw new RuntimeException("症状为空,导入数据失败"); |
| | | } else { |
| | | zfDoctorService.addData(zfDoctor); |
| | | // if (zfDoctor.getSuitable().length() != 0 || zfDoctor.getType().length() != 0 || zfDoctor.getEffect().length() != 0 ) { |
| | | if(zfDoctor.getSymptom().length() == 0 || zfDoctor.getSymptom() == null){ |
| | | throw new RuntimeException("症状为空,导入数据失败"); |
| | | } |
| | | else { |
| | | zfDoctorService.addData(zfDoctor); |
| | | } |
| | | } |
| | | } |
| | | // } |
| | | return AjaxResult.success("导入数据成功"); |
| | | |
| | | } |
| | |
| | | |
| | | // List<ZfDoctorShare> authority1 = zfDoctorShareService.getAuthority(); |
| | | // List<Long> idList1 = authority1.stream().filter(auth -> auth.getShareContent().toString().equals(DOCTOR_LIST)).map(ZfDoctorShare::getShareId).collect(Collectors.toList()); |
| | | zfDoctorService.addData(zfDoctor); |
| | | // zfDoctorService.addData(zfDoctor); |
| | | |
| | | if (zfDoctor.getFamilyId() != null && !familyIdList.contains(zfDoctor.getFamilyId())) { |
| | | throw new RuntimeException("你没有权限操作此家庭的数据"); |
| | |
| | | } |
| | | } |
| | | List<ZfDoctor> zfDoctors = listByIds(Arrays.asList(ids)); |
| | | |
| | | if (! (zfDoctorDownloadService.deleteData(ids) && zfDoctorShareService.deleteByContentId(ids) ) ){ |
| | | return AjaxResult.error(); |
| | | } |
| | | if (zfDoctorService.removeByIds(Arrays.asList(ids))) { |
| | | |
| | | //删除es中的数据 |
| | |
| | | return lqw; |
| | | } |
| | | |
| | | // public LambdaQueryWrapper<ZfDoctor> buildCondition2(List<Long> ids) { |
| | | // LambdaQueryWrapper<ZfDoctor> lqw = new LambdaQueryWrapper<>(); |
| | | // lqw.eq(ZfDoctor::getId, ids); |
| | | // |
| | | // return lqw; |
| | | // } |
| | | // @Override |
| | | // public AjaxResult selectListById(List<Long> ids, Integer pageNum, Integer pageSize) { |
| | | // List<ZfDoctor> lqw2 = new ArrayList<>(); |
| | | // |
| | | // LambdaQueryWrapper<ZfDoctor> lqw = buildCondition2(ids); |
| | | // List<ZfDoctor> bb = list(lqw); |
| | | // System.out.println("15052222254"+bb); |
| | | // |
| | | // Page<ZfDoctor> zfDoctorPage = new Page<>(pageNum, pageSize); |
| | | // Page<ZfDoctor> pageResult = page(zfDoctorPage, lqw); |
| | | // List<ZfDoctor> beanRecords = pageResult.getRecords();//得到查询出来的数据 |
| | | // System.out.println(beanRecords); |
| | | // |
| | | // HashMap<String, Object> data = MapUtils.getResult(pageResult, beanRecords); |
| | | // |
| | | // |
| | | // return AjaxResult.success(data); |
| | | //// } |
| | | |
| | | // private List<Long> buildCondition1(){ |
| | | // List<ZfDoctorShare> authority1 = zfDoctorShareService.getAuthority(); |
| | | // List<Long> idList1 = authority1.stream().filter(auth -> auth.getShareContent().toString().equals(DOCTOR_LIST)).map(ZfDoctorShare::getShareId).collect(Collectors.toList()); |