| | |
| | | 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.ZInfoUser; |
| | | import com.ruoyi.domain.ZfEvent; |
| | | import com.ruoyi.domain.ZfEvent; |
| | | import com.ruoyi.domain.ZfProperty; |
| | | import com.ruoyi.mapper.ZfEventMapper; |
| | | import com.ruoyi.service.ZInfoUserService; |
| | | import com.ruoyi.service.ZfEventService; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.util.HashMap; |
| | |
| | | |
| | | @Resource |
| | | ZInfoUserService zInfoUserService; |
| | | |
| | | private String listFamilyIds(){ |
| | | |
| | | @Resource |
| | | ZfEventService zfEventService; |
| | | |
| | | private String listFamilyIds() { |
| | | SysUser user = SecurityUtils.getLoginUser().getUser(); |
| | | Long userId = user.getUserId(); |
| | | LambdaQueryWrapper<ZInfoUser> zInfoUserLambdaQueryWrapper = new LambdaQueryWrapper<>(); |
| | | zInfoUserLambdaQueryWrapper.eq(ZInfoUser::getUserId,userId); |
| | | zInfoUserLambdaQueryWrapper.eq(ZInfoUser::getUserId, userId); |
| | | ZInfoUser zInfoUser = zInfoUserService.getOne(zInfoUserLambdaQueryWrapper); |
| | | return zInfoUser.getFamilyId(); |
| | | } |
| | | |
| | | |
| | | |
| | | @Override |
| | | public AjaxResult selectEventList(ZfEvent zfEvent, Integer pageNum, Integer pageSize) { |
| | | String familyIds = listFamilyIds(); |
| | | LambdaQueryWrapper<ZfEvent> lqw = buildCondition(zfEvent,familyIds); |
| | | LambdaQueryWrapper<ZfEvent> lqw = buildCondition(zfEvent, familyIds); |
| | | |
| | | Page<ZfEvent> ZfEventPage = new Page<>(pageNum,pageSize); |
| | | Page<ZfEvent> ZfEventPage = new Page<>(pageNum, pageSize); |
| | | Page<ZfEvent> pageResult = page(ZfEventPage, lqw); |
| | | |
| | | HashMap<String, Object> data = MapUtils.getResult(pageResult); |
| | | return AjaxResult.success(data); |
| | | } |
| | | |
| | | |
| | | |
| | | @Override |
| | | public List<ZfEvent> selectByCondition(ZfEvent zfEvent) { |
| | | String familyIds = listFamilyIds(); |
| | | LambdaQueryWrapper<ZfEvent> lqw = buildCondition(zfEvent,familyIds); |
| | | LambdaQueryWrapper<ZfEvent> lqw = buildCondition(zfEvent, familyIds); |
| | | List<ZfEvent> list = list(lqw); |
| | | log.info("返回的数据为:{}",list); |
| | | log.info("返回的数据为:{}", list); |
| | | return list; |
| | | } |
| | | |
| | | @Override |
| | | public int addEvent(ZfEvent zfEvent) { |
| | | String familyIds = listFamilyIds(); |
| | | boolean flag = false;//判断当前用户的id是否有权加入当前家庭id的对象 |
| | | if (familyIds.contains(",")) { |
| | | String[] familyList = familyIds.split(","); |
| | | for (String familyId : familyList) { |
| | | if (familyId.equals(zfEvent.getFamilyId())) { |
| | | flag = true; |
| | | } |
| | | } |
| | | } else { |
| | | if (zfEvent.getFamilyId().equals(familyIds)) { |
| | | flag = true; |
| | | } |
| | | } |
| | | if (flag) { |
| | | boolean save = save(zfEvent); |
| | | return save ? 1 : 0; |
| | | } else { |
| | | throw new RuntimeException("你没有操作该家庭号为" + zfEvent.getFamilyId() + "数据的权限"); |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | public AjaxResult importExcel(MultipartFile file) { |
| | | ExcelUtil<ZfEvent> util = new ExcelUtil<>(ZfEvent.class); |
| | | List<ZfEvent> eventList = null; |
| | | try { |
| | | eventList = util.importExcel(file.getInputStream()); |
| | | } catch (Exception e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | log.info("资产列表为:{}", eventList); |
| | | |
| | | for (ZfEvent zfEvent : eventList) { |
| | | zfEventService.addEvent(zfEvent); |
| | | } |
| | | |
| | | return AjaxResult.success("导入数据成功"); |
| | | } |
| | | |
| | | private LambdaQueryWrapper<ZfEvent> buildCondition(ZfEvent zfEvent) { |
| | | LambdaQueryWrapper<ZfEvent> lqw = new LambdaQueryWrapper<>(); |
| | | lqw.like(!StringUtils.isEmpty(zfEvent.getAddress()),ZfEvent::getAddress,zfEvent.getAddress()); |
| | | lqw.like(!StringUtils.isEmpty(zfEvent.getPeople()),ZfEvent::getPeople,zfEvent.getPeople()); |
| | | lqw.like(!StringUtils.isEmpty(zfEvent.getTitle()),ZfEvent::getTitle,zfEvent.getTitle()); |
| | | lqw.like(!StringUtils.isEmpty(zfEvent.getRemark()),ZfEvent::getRemark,zfEvent.getRemark()); |
| | | lqw.like(zfEvent.getCreateTime()!=null,ZfEvent::getCreateTime,zfEvent.getCreateTime()); |
| | | lqw.like(!StringUtils.isEmpty(zfEvent.getAddress()), ZfEvent::getAddress, zfEvent.getAddress()); |
| | | lqw.like(!StringUtils.isEmpty(zfEvent.getPeople()), ZfEvent::getPeople, zfEvent.getPeople()); |
| | | lqw.like(!StringUtils.isEmpty(zfEvent.getTitle()), ZfEvent::getTitle, zfEvent.getTitle()); |
| | | lqw.like(!StringUtils.isEmpty(zfEvent.getRemark()), ZfEvent::getRemark, zfEvent.getRemark()); |
| | | lqw.eq(zfEvent.getHappenTime() != null, ZfEvent::getHappenTime, zfEvent.getHappenTime()); |
| | | lqw.between(zfEvent.getHappenStartTime() != null && zfEvent.getHappenEndTime() != null, ZfEvent::getHappenTime, zfEvent.getHappenStartTime(), zfEvent.getHappenEndTime()); |
| | | return lqw; |
| | | } |
| | | |
| | |
| | | LambdaQueryWrapper<ZfEvent> lqw = buildCondition(zfEvent); |
| | | if (familyIds.contains(",")) { |
| | | String[] familyList = familyIds.split(","); |
| | | for (String familyId : familyList) { |
| | | lqw.or().eq(ZfEvent::getFamilyId,familyId); |
| | | } |
| | | }else { |
| | | lqw.eq(ZfEvent::getFamilyId,familyIds); |
| | | lqw.in(ZfEvent::getFamilyId, familyList); |
| | | } else { |
| | | lqw.eq(ZfEvent::getFamilyId, familyIds); |
| | | } |
| | | return lqw; |
| | | } |