| | |
| | | package com.ruoyi.service.impl; |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.ruoyi.common.core.domain.AjaxResult; |
| | | import com.ruoyi.common.core.domain.entity.EsModel; |
| | | import com.ruoyi.common.core.domain.entity.SysUser; |
| | | |
| | | import com.ruoyi.common.utils.MapUtils; |
| | | import com.ruoyi.common.utils.SecurityUtils; |
| | | import com.ruoyi.common.utils.StringUtils; |
| | | import com.ruoyi.common.utils.bean.BeanUtils; |
| | | import com.ruoyi.common.utils.poi.ExcelUtil; |
| | | import com.ruoyi.constant.MenuAuthority; |
| | | import com.ruoyi.domain.*; |
| | | import com.ruoyi.mapper.ZfPropertyMapper; |
| | | import com.ruoyi.service.*; |
| | | import com.ruoyi.util.ArraysUtil; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.elasticsearch.action.delete.DeleteRequest; |
| | | import org.elasticsearch.action.update.UpdateRequest; |
| | |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.io.IOException; |
| | | import java.text.ParseException; |
| | | import java.text.SimpleDateFormat; |
| | | import java.time.LocalDateTime; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | |
| | | |
| | | @Resource |
| | | RestHighLevelClient restHighLevelClient; |
| | | |
| | | @Resource |
| | | private IZfPropertyDownloadService zfPropertyDownloadService; |
| | | |
| | | @Resource |
| | | private IZfPropertyShareService iZfPropertyShareService; |
| | | |
| | | @Resource |
| | | private MemoBookService memoBookService; |
| | | |
| | | |
| | | // private LambdaQueryWrapper<ZfProperty> buildCondition(ZfProperty zfProperty) { |
| | |
| | | //要查自己家庭的 |
| | | 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(PROPERTY_LIST)).map(ZAuthority::getFid).collect(Collectors.toList()); |
| | | //加上自己家庭的id |
| | | idList.add(familyId); |
| | | |
| | | //加上父母家族id |
| | | idList.add(fatherFaId); |
| | | idList.add(motherFaId); |
| | | |
| | | // String familyIds = listFamilyIds(); |
| | | // String secondFamilyAuthority = listSecondFamilyIds(); |
| | | LambdaQueryWrapper<ZfProperty> lqw = buildCondition(zfProperty, idList); |
| | | List<ZfProperty> beanRecords = list(lqw); |
| | | log.info("从数据库中查到的为:{}", beanRecords); |
| | | return markOwnData(familyId, beanRecords); |
| | | return markOwnData(familyId, fatherFaId, motherFaId, beanRecords); |
| | | } |
| | | |
| | | // private static List<ZfProperty> markOwnData(String familyIds, List<ZfProperty> beanRecords) { |
| | |
| | | //也要查别人授权的 |
| | | List<ZAuthority> authority = zAuthorityService.getAuthority(); |
| | | List<Long> idList = authority.stream().filter(auth -> auth.getAuthority().toString().equals(PROPERTY_LIST)).map(ZAuthority::getFid).collect(Collectors.toList()); |
| | | |
| | | //查看父母的数据: |
| | | 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(); |
| | | |
| | | //加上自己家庭的id |
| | | idList.add(familyId); |
| | | |
| | | //加上父母家族id |
| | | idList.add(fatherFaId); |
| | | idList.add(motherFaId); |
| | | |
| | | // String familyIds = listFamilyIds(); |
| | | // String secondFamilyAuthority = listSecondFamilyIds(); |
| | | LambdaQueryWrapper<ZfProperty> lqw = buildCondition(zfProperty, idList); |
| | |
| | | |
| | | List<ZfProperty> beanRecords = pageResult.getRecords();//得到查询出来的数据 |
| | | |
| | | List<ZfProperty> dtoResult = markOwnData(familyId, beanRecords); |
| | | List<ZfProperty> dtoResult = markOwnData(familyId,fatherFaId, motherFaId, beanRecords); |
| | | |
| | | HashMap<String, Object> data = MapUtils.getResult(pageResult, dtoResult); |
| | | return AjaxResult.success(data); |
| | | } |
| | | |
| | | public List<ZfProperty> markOwnData(Long familyId,List<ZfProperty> beanRecords){ |
| | | public List<ZfProperty> markOwnData(Long familyId,Long fatherFamilyId, Long motherFamilyId,List<ZfProperty> 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); |
| | |
| | | else |
| | | list = list(); |
| | | return list; |
| | | } |
| | | |
| | | @Override |
| | | public AjaxResult selectType() { |
| | | List<String> lis = list(new QueryWrapper<ZfProperty>().select("distinct (type)").lambda()).stream().map(ZfProperty::getType).collect(Collectors.toList()); |
| | | return AjaxResult.success(lis); |
| | | } |
| | | |
| | | @Override |
| | |
| | | if (!familyIdList.contains(data.getFamilyId())){ |
| | | throw new RuntimeException("你没有权限操作此家庭的数据"); |
| | | } |
| | | List<MemoBook> memoBookService1 = memoBookService.selectByIdAFid(data.getId().longValue(),2007L); |
| | | if (!memoBookService.removeByIds(memoBookService1)) |
| | | return AjaxResult.error(); |
| | | |
| | | } |
| | | |
| | | List<ZfProperty> zfPropertys = listByIds(Arrays.asList(ids)); |
| | | |
| | | if (! (zfPropertyDownloadService.deleteData(ids) && iZfPropertyShareService.deleteByContentId(ids))){ |
| | | return AjaxResult.error(); |
| | | } |
| | | if (zfPropertyService.removeByIds(Arrays.asList(ids))) { |
| | | |
| | | //删除es中的数据 |
| | |
| | | throw new RuntimeException(e); |
| | | }} |
| | | }); |
| | | System.out.println("15165132165346153246153"); |
| | | |
| | | return AjaxResult.success(); |
| | | }else { |
| | | return AjaxResult.error(); |