| | |
| | | package com.ruoyi.service.impl; |
| | | |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | 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.SysUser; |
| | | import com.ruoyi.common.utils.MapUtils; |
| | | import com.ruoyi.common.utils.SecurityUtils; |
| | | import com.ruoyi.common.utils.StringUtils; |
| | | import com.ruoyi.common.utils.poi.ExcelUtil; |
| | | import com.ruoyi.domain.ZHonor; |
| | | import com.ruoyi.domain.ZInfoUser; |
| | | import com.ruoyi.domain.ZProperty; |
| | | import com.ruoyi.mapper.ZPropertyMapper; |
| | | import com.ruoyi.service.ZInfoUserService; |
| | | import com.ruoyi.service.ZPropertyService; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.util.ArrayList; |
| | | import java.util.Arrays; |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.stream.Collectors; |
| | | |
| | | /** |
| | | * <p> |
| | |
| | | @Service |
| | | public class ZPropertyServiceImpl extends ServiceImpl<ZPropertyMapper, ZProperty> implements ZPropertyService { |
| | | |
| | | @Autowired |
| | | ZPropertyServiceImpl zPropertyService; |
| | | @Autowired |
| | | ZInfoUserService zInfoUserService; |
| | | @Resource |
| | | ZPropertyMapper zPropertyMapper; |
| | | |
| | | private LambdaQueryWrapper<ZProperty> uniqueCondition(ZProperty zProperty) { |
| | | LambdaQueryWrapper<ZProperty> lqw = new LambdaQueryWrapper<>(); |
| | | lqw.eq(StringUtils.isNotEmpty(zProperty.getType()), ZProperty::getType, zProperty.getType()) |
| | | .eq(StringUtils.isNotEmpty(zProperty.getIncomeName()), ZProperty::getIncomeName, zProperty.getIncomeName()) |
| | | .eq(StringUtils.isNotEmpty(zProperty.getPrice()), ZProperty::getPrice, zProperty.getPrice()) |
| | | .eq(StringUtils.isNotEmpty(zProperty.getTimeLimit()), ZProperty::getTimeLimit, zProperty.getTimeLimit()) |
| | | .eq(StringUtils.isNotEmpty(zProperty.getIsChange()), ZProperty::getIsChange, zProperty.getIsChange()) |
| | | .eq(StringUtils.isNotEmpty(zProperty.getPropertyRight()), ZProperty::getPropertyRight, zProperty.getPropertyRight()) |
| | | .eq(zProperty.getHappenTime() != null, ZProperty::getHappenTime, zProperty.getHappenTime()) |
| | | .eq(StringUtils.isNotEmpty(zProperty.getLocation()), ZProperty::getLocation, zProperty.getLocation()) |
| | | .eq(StringUtils.isNotEmpty(zProperty.getRemark()), ZProperty::getRemark, zProperty.getRemark()) |
| | | .eq(zProperty.getUserId() != null, ZProperty::getUserId, zProperty.getUserId()); |
| | | return lqw; |
| | | } |
| | | |
| | | private LambdaQueryWrapper<ZProperty> buildCondition(ZProperty zProperty, Long userId) { |
| | | LambdaQueryWrapper<ZProperty> lqw = new LambdaQueryWrapper<>(); |
| | | lqw.eq(userId != null, ZProperty::getUserId, userId) |
| | | .like(StringUtils.isNotEmpty(zProperty.getType()), ZProperty::getType, zProperty.getType()) |
| | | .like(StringUtils.isNotEmpty(zProperty.getIncomeName()), ZProperty::getIncomeName, zProperty.getIncomeName()) |
| | | .like(StringUtils.isNotEmpty(zProperty.getType()), ZProperty::getType, zProperty.getType()) |
| | | .like(StringUtils.isNotEmpty(zProperty.getIsChange()),ZProperty::getIsChange,zProperty.getIsChange()) |
| | | .like(StringUtils.isNotEmpty(zProperty.getRemark()), ZProperty::getRemark, zProperty.getRemark()) |
| | | .like(StringUtils.isNotEmpty(zProperty.getTimeLimit()),ZProperty::getTimeLimit,zProperty.getTimeLimit()) |
| | | .eq(zProperty.getStatus()!=null,ZProperty::getStatus,zProperty.getStatus()) |
| | | .between(zProperty.getHappenStartTime() != null && zProperty.getHappenEndTime() != null, ZProperty::getHappenTime, zProperty.getHappenStartTime(), zProperty.getHappenEndTime()) |
| | | .orderByDesc(ZProperty::getCreateTime); |
| | | return lqw; |
| | | } |
| | | private LambdaQueryWrapper<ZProperty> buildConditionSec(ZProperty zProperty, List<Long> userId) { |
| | | LambdaQueryWrapper<ZProperty> lqw = new LambdaQueryWrapper<>(); |
| | | lqw.in(ZProperty::getUserId, userId) |
| | | .like(StringUtils.isNotEmpty(zProperty.getType()), ZProperty::getType, zProperty.getType()) |
| | | .like(StringUtils.isNotEmpty(zProperty.getIncomeName()), ZProperty::getIncomeName, zProperty.getIncomeName()) |
| | | .like(StringUtils.isNotEmpty(zProperty.getType()), ZProperty::getType, zProperty.getType()) |
| | | .like(StringUtils.isNotEmpty(zProperty.getIsChange()),ZProperty::getIsChange,zProperty.getIsChange()) |
| | | .like(StringUtils.isNotEmpty(zProperty.getRemark()), ZProperty::getRemark, zProperty.getRemark()) |
| | | .like(StringUtils.isNotEmpty(zProperty.getTimeLimit()),ZProperty::getTimeLimit,zProperty.getTimeLimit()) |
| | | .eq(zProperty.getStatus()!=null,ZProperty::getStatus,zProperty.getStatus()) |
| | | .between(zProperty.getHappenStartTime() != null && zProperty.getHappenEndTime() != null, ZProperty::getHappenTime, zProperty.getHappenStartTime(), zProperty.getHappenEndTime()) |
| | | .orderByDesc(ZProperty::getCreateTime); |
| | | return lqw; |
| | | } |
| | | |
| | | /** |
| | | * 分页查找 |
| | | */ |
| | | @Override |
| | | public AjaxResult selectDataList(ZProperty zProperty, Integer pageNum, Integer pageSize) { |
| | | SysUser user = SecurityUtils.getLoginUser().getUser(); |
| | | Long userId = user.getUserId(); |
| | | |
| | | //根据userId查询到infouser的uaid |
| | | ZInfoUser zInfoUser = zInfoUserService.getInfoBysysId(userId); |
| | | //拿到所有的sysid |
| | | List<Long> fms = zInfoUserService.findByUaidToFaid(zInfoUser.getUaid()).stream().map(ZInfoUser::getSysId).collect(Collectors.toList()); |
| | | LambdaQueryWrapper<ZProperty> lqw; |
| | | if(!fms.isEmpty()) |
| | | lqw = buildConditionSec(zProperty, fms); |
| | | else |
| | | lqw = buildCondition(zProperty, userId); |
| | | |
| | | Page<ZProperty> pageBean = new Page<>(pageNum, pageSize); |
| | | Page<ZProperty> pageResult = page(pageBean, lqw); |
| | | |
| | | List<ZProperty> beanRecords = pageResult.getRecords();//得到查询出来的数据 |
| | | |
| | | HashMap<String, Object> data = MapUtils.getResult(pageResult, beanRecords); |
| | | return AjaxResult.success(data); |
| | | |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public List<ZProperty> selectByIds(Long[] ids) { |
| | | List<ZProperty> list = new ArrayList<>(); |
| | | if (ids.length != 0) |
| | | list = listByIds(Arrays.asList(ids)); |
| | | else |
| | | list = list(); |
| | | return list; |
| | | } |
| | | |
| | | @Override |
| | | public AjaxResult mySave(ZProperty zProperty) { |
| | | SysUser user = SecurityUtils.getLoginUser().getUser(); |
| | | Long userId = user.getUserId(); |
| | | zProperty.setUserId(userId); |
| | | |
| | | //检查是否有重复数据插入 |
| | | LambdaQueryWrapper<ZProperty> lqw = uniqueCondition(zProperty); |
| | | List<ZProperty> list = list(lqw); |
| | | if (list.size() > 0) { |
| | | throw new RuntimeException("请勿新增重复数据"); |
| | | } |
| | | |
| | | if (save(zProperty)) { |
| | | return AjaxResult.success(); |
| | | } else { |
| | | return AjaxResult.error(); |
| | | } |
| | | |
| | | } |
| | | |
| | | @Override |
| | | public List<ZProperty> selectByCondition() { |
| | | SysUser user = SecurityUtils.getLoginUser().getUser(); |
| | | Long userId = user.getUserId(); |
| | | ZProperty zProperty = new ZProperty(); |
| | | LambdaQueryWrapper<ZProperty> lqw = buildCondition(zProperty, userId); |
| | | return list(lqw); |
| | | } |
| | | |
| | | @Override |
| | | public AjaxResult listType() { |
| | | List<String> result = zPropertyMapper.listType(); |
| | | return AjaxResult.success(result); |
| | | } |
| | | |
| | | @Override |
| | | @Transactional |
| | | public AjaxResult importExcel(MultipartFile file) { |
| | | |
| | | ExcelUtil<ZProperty> util = new ExcelUtil<>(ZProperty.class); |
| | | List<ZProperty> dataList = null; |
| | | try { |
| | | dataList = util.importExcel(file.getInputStream()); |
| | | } catch (Exception e) { |
| | | throw new RuntimeException("没有按照规则导入数据"); |
| | | } |
| | | |
| | | assert dataList != null; |
| | | |
| | | for (ZProperty zProperty : dataList) { |
| | | zPropertyService.mySave(zProperty); |
| | | } |
| | | |
| | | return AjaxResult.success(); |
| | | |
| | | } |
| | | |
| | | } |