| | |
| | | sysUserDO.setPhone(purePhoneNumber); |
| | | sysUserDO.setUserId(userId); |
| | | userDao.updateMemberRole(purePhoneNumber, purePhoneNumber); |
| | | userDao.updateServiceTeam(purePhoneNumber, purePhoneNumber); |
| | | userDao.updateServiceTeam(purePhoneNumber, purePhoneNumber); |
| | | int i = userDao.updateById(sysUserDO); |
| | | if (i > 0) { |
| | | return R.ok(); |
| | |
| | | sysUserDO = userDao.selectOne(new QueryWrapper<SysUserDO>().lambda().eq(SysUserDO::getType, type).eq(SysUserDO::getOpenid, name)); |
| | | } else { |
| | | LambdaQueryWrapper<SysUserDO> wrapper = new QueryWrapper<SysUserDO>().lambda().eq(SysUserDO::getType, type); |
| | | wrapper.and(sysUserDOLambdaQueryWrapper ->sysUserDOLambdaQueryWrapper .eq(SysUserDO::getAccount, name).or().eq(SysUserDO::getPhone, name)); |
| | | wrapper.and(sysUserDOLambdaQueryWrapper -> sysUserDOLambdaQueryWrapper.eq(SysUserDO::getAccount, name).or().eq(SysUserDO::getPhone, name)); |
| | | sysUserDO = userDao.selectOne(wrapper); |
| | | } |
| | | boolean empty = ObjectUtils.isEmpty(sysUserDO); |
| | | if (empty) { |
| | | return R.fail(); |
| | | } |
| | | LoginUserInfoVO loginUserInfoVO=new LoginUserInfoVO(); |
| | | LoginUserInfoVO loginUserInfoVO = new LoginUserInfoVO(); |
| | | loginUserInfoVO.setUserId(sysUserDO.getUserId()); |
| | | loginUserInfoVO.setName(sysUserDO.getName()); |
| | | loginUserInfoVO.setPassword(sysUserDO.getPassword()); |
| | | loginUserInfoVO.setStatus(sysUserDO.getStatus()); |
| | | loginUserInfoVO.setAccount(name); |
| | | loginUserInfoVO.setType(sysUserDO.getType()); |
| | | List<SysRoleDO> roleDOList=roleDAO.selectByUserId(sysUserDO.getUserId()); |
| | | Set<String> set=new HashSet<>(); |
| | | List<SysRoleDO> roleDOList = roleDAO.selectByUserId(sysUserDO.getUserId()); |
| | | Set<String> set = new HashSet<>(); |
| | | if (!ObjectUtils.isEmpty(roleDOList)) { |
| | | roleDOList.forEach(sysRoleDO -> { |
| | | set.add(sysRoleDO.getRoleKey()); |
| | |
| | | if (empty) { |
| | | return R.fail(); |
| | | } |
| | | LoginUserInfoVO loginUserInfoVO=new LoginUserInfoVO(); |
| | | BeanUtils.copyProperties(sysUserDO,loginUserInfoVO); |
| | | List<SysRoleDO> roleDOList=roleDAO.selectByUserId(sysUserDO.getUserId()); |
| | | Set<String> set=new HashSet<>(); |
| | | LoginUserInfoVO loginUserInfoVO = new LoginUserInfoVO(); |
| | | BeanUtils.copyProperties(sysUserDO, loginUserInfoVO); |
| | | List<SysRoleDO> roleDOList = roleDAO.selectByUserId(sysUserDO.getUserId()); |
| | | Set<String> set = new HashSet<>(); |
| | | if (!ObjectUtils.isEmpty(roleDOList)) { |
| | | roleDOList.forEach(sysRoleDO -> { |
| | | set.add(sysRoleDO.getRoleKey()); |
| | |
| | | // 志愿者状态 |
| | | String phone = sysUserDO.getPhone(); |
| | | if (!ObjectUtils.isEmpty(phone)) { |
| | | ComMngVolunteerMngVO comMngVolunteerMngVO= userDao.selectVolunteerMngByPhone(phone); |
| | | ComMngVolunteerMngVO comMngVolunteerMngVO = userDao.selectVolunteerMngByPhone(phone); |
| | | if (ObjectUtils.isEmpty(comMngVolunteerMngVO)) { |
| | | loginUserInfoVO.setVolunteerStatus(0); |
| | | }else{ |
| | | } else { |
| | | int state = comMngVolunteerMngVO.getState().intValue(); |
| | | loginUserInfoVO.setVolunteerStatus(state); |
| | | } |
| | | Integer countTeam = userDao.selectCountTeam(phone); |
| | | Integer selectCountMemberRole = userDao.selectCountMemberRole(phone); |
| | | Integer isSysUser = userDao.selectCountSysUser(phone); |
| | | if(countTeam!=null&&countTeam>0) { |
| | | loginUserInfoVO.setIsmemberrole(1); |
| | | }else if(selectCountMemberRole!=null&&selectCountMemberRole>0) { |
| | | loginUserInfoVO.setIsmemberrole(1); |
| | | }else if(isSysUser!=null && isSysUser>0){ |
| | | if (countTeam != null && countTeam > 0) { |
| | | loginUserInfoVO.setIsmemberrole(1); |
| | | } else if (selectCountMemberRole != null && selectCountMemberRole > 0) { |
| | | loginUserInfoVO.setIsmemberrole(1); |
| | | } else if (isSysUser != null && isSysUser > 0) { |
| | | loginUserInfoVO.setIsmemberrole(1); |
| | | } |
| | | } |
| | |
| | | return R.fail("新密码与原密码不能相同"); |
| | | } |
| | | BCryptPasswordEncoder encoder = new BCryptPasswordEncoder(); |
| | | if( !encoder.matches(oldPassword,dataPassowrd)){ |
| | | if (!encoder.matches(oldPassword, dataPassowrd)) { |
| | | return R.fail("原密码错误"); |
| | | |
| | | } |
| | | SysUserDO sysUserDO=new SysUserDO(); |
| | | SysUserDO sysUserDO = new SysUserDO(); |
| | | sysUserDO.setUserId(userId); |
| | | String encode = new BCryptPasswordEncoder().encode(newPassword); |
| | | sysUserDO.setPassword(encode); |
| | | int update = userDao.updateById(sysUserDO); |
| | | if (update>0) { |
| | | if (update > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | |
| | | */ |
| | | @Override |
| | | public R listActivityManager(String param, Long communityId) { |
| | | LambdaQueryWrapper<SysUserDO> queryWrapper=new LambdaQueryWrapper<>(); |
| | | List<ActivityManagerVO> activityManagerVOS=new ArrayList<>(); |
| | | queryWrapper = new QueryWrapper<SysUserDO>().lambda().eq(SysUserDO::getCommunityId, communityId).eq(SysUserDO::getStatus, 1).eq(SysUserDO::getType,3); |
| | | LambdaQueryWrapper<SysUserDO> queryWrapper = new LambdaQueryWrapper<>(); |
| | | List<ActivityManagerVO> activityManagerVOS = new ArrayList<>(); |
| | | queryWrapper = new QueryWrapper<SysUserDO>().lambda().eq(SysUserDO::getCommunityId, communityId).eq(SysUserDO::getStatus, 1).eq(SysUserDO::getType, 3); |
| | | if (!ObjectUtils.isEmpty(param)) { |
| | | queryWrapper = queryWrapper.eq(SysUserDO::getName, param); |
| | | } |
| | | List<SysUserDO> sysUserDOS = userDao.selectList(queryWrapper); |
| | | if (!ObjectUtils.isEmpty(sysUserDOS)) { |
| | | sysUserDOS.forEach(sysUserDO -> { |
| | | ActivityManagerVO activityManagerVO=new ActivityManagerVO(); |
| | | ActivityManagerVO activityManagerVO = new ActivityManagerVO(); |
| | | activityManagerVO.setManagerId(sysUserDO.getUserId()); |
| | | activityManagerVO.setName(sysUserDO.getName()); |
| | | activityManagerVOS.add(activityManagerVO); |
| | |
| | | Page page = new Page<>(); |
| | | Long pageNum = loginUserInfoVO.getPageNum(); |
| | | Long pageSize = loginUserInfoVO.getPageSize(); |
| | | if (null==pageNum||0==pageNum) { |
| | | if (null == pageNum || 0 == pageNum) { |
| | | pageNum = 1l; |
| | | } |
| | | if (null==pageSize||0==pageSize) { |
| | | if (null == pageSize || 0 == pageSize) { |
| | | pageSize = 10l; |
| | | } |
| | | page.setSize(pageSize); |
| | |
| | | public R putUserFace(LoginUserInfoVO loginUserInfoVO) { |
| | | int operationType = loginUserInfoVO.getOperationType().intValue(); |
| | | Long userId = loginUserInfoVO.getUserId(); |
| | | SysUserDO sysUserDO=new SysUserDO(); |
| | | SysUserDO sysUserDO = new SysUserDO(); |
| | | sysUserDO.setUserId(userId); |
| | | switch (operationType){ |
| | | switch (operationType) { |
| | | case 1: |
| | | sysUserDO.setFaceState(1); |
| | | break; |
| | |
| | | default: |
| | | break; |
| | | } |
| | | int num=0; |
| | | if (operationType==3) { |
| | | int num = 0; |
| | | if (operationType == 3) { |
| | | // num=userDao.deleteById(userId); |
| | | num=userDao.updateFaceState(userId); |
| | | num = userDao.updateFaceState(userId); |
| | | } else { |
| | | num=userDao.updateById(sysUserDO); |
| | | num = userDao.updateById(sysUserDO); |
| | | } |
| | | if (num>0) { |
| | | if (num > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | |
| | | Page page = new Page<>(); |
| | | Long pageNum = loginUserInfoVO.getPageNum(); |
| | | Long pageSize = loginUserInfoVO.getPageSize(); |
| | | if (null==pageNum||0==pageNum) { |
| | | if (null == pageNum || 0 == pageNum) { |
| | | pageNum = 1l; |
| | | } |
| | | if (null==pageSize||0==pageSize) { |
| | | if (null == pageSize || 0 == pageSize) { |
| | | pageSize = 10l; |
| | | } |
| | | page.setSize(pageSize); |
| | | page.setCurrent(pageNum); |
| | | IPage<LoginUserInfoVO> iPage = userDao.pageUser(page, loginUserInfoVO); |
| | | iPage.getRecords().forEach(record->{ |
| | | iPage.getRecords().forEach(record -> { |
| | | record.setPhone(SensitiveUtil.desensitizedPhoneNumber(record.getPhone())); |
| | | record.setIdCard(SensitiveUtil.desensitizedIdNumber(record.getIdCard())); |
| | | }); |
| | |
| | | */ |
| | | @Override |
| | | public R listTag() { |
| | | List<String> list=new ArrayList<>(); |
| | | List<String> list = new ArrayList<>(); |
| | | List<ComMngUserTagDO> comMngUserTagDOS = comMngUserTagDAO.selectList(new LambdaQueryWrapper<>()); |
| | | if (!ObjectUtils.isEmpty(comMngUserTagDOS)) { |
| | | list=comMngUserTagDOS.stream().map(comMngUserTagDO -> comMngUserTagDO.getTagName()).collect(Collectors.toList()); |
| | | list = comMngUserTagDOS.stream().map(comMngUserTagDO -> comMngUserTagDO.getTagName()).collect(Collectors.toList()); |
| | | } |
| | | return R.ok(list); |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public R detailUser(Long userId) { |
| | | LoginUserInfoVO loginUserInfoVO=new LoginUserInfoVO(); |
| | | if(userId<100000000l){ |
| | | LoginUserInfoVO loginUserInfoVO = new LoginUserInfoVO(); |
| | | if (userId < 100000000l) { |
| | | SysUserDO sysUserDO = userDao.selectById(userId); |
| | | if (ObjectUtils.isEmpty(sysUserDO)) { |
| | | return R.fail("人员不存在"); |
| | | } |
| | | BeanUtils.copyProperties(sysUserDO,loginUserInfoVO); |
| | | BeanUtils.copyProperties(sysUserDO, loginUserInfoVO); |
| | | List<ComMngFamilyInfoDO> comMngFamilyInfoDOS = comMngFamilyInfoDAO.selectList(new QueryWrapper<ComMngFamilyInfoDO>().lambda().eq(ComMngFamilyInfoDO::getUserId, userId)); |
| | | if (!ObjectUtils.isEmpty(comMngFamilyInfoDOS)) { |
| | | List<ComMngFamilyInfoVO>comMngFamilyInfoVOS=new ArrayList<>(); |
| | | List<ComMngFamilyInfoVO> comMngFamilyInfoVOS = new ArrayList<>(); |
| | | comMngFamilyInfoDOS.forEach(comMngFamilyInfoDO -> { |
| | | ComMngFamilyInfoVO comMngFamilyInfoVO=new ComMngFamilyInfoVO(); |
| | | BeanUtils.copyProperties(comMngFamilyInfoDO,comMngFamilyInfoVO); |
| | | ComMngFamilyInfoVO comMngFamilyInfoVO = new ComMngFamilyInfoVO(); |
| | | BeanUtils.copyProperties(comMngFamilyInfoDO, comMngFamilyInfoVO); |
| | | comMngFamilyInfoVOS.add(comMngFamilyInfoVO); |
| | | }); |
| | | loginUserInfoVO.setComMngFamilyInfoVOS(comMngFamilyInfoVOS); |
| | | } |
| | | |
| | | }else{ |
| | | } else { |
| | | //导入社区人员 |
| | | SysUserInputDO sysUserInputDO = sysUserInputDAO.selectById(userId - 100000000); |
| | | if (ObjectUtils.isEmpty(sysUserInputDO)) { |
| | | return R.fail("人员不存在"); |
| | | } |
| | | String name1 = sysUserInputDO.getName(); |
| | | BeanUtils.copyProperties(sysUserInputDO,loginUserInfoVO); |
| | | BeanUtils.copyProperties(sysUserInputDO, loginUserInfoVO); |
| | | String doorNumber = sysUserInputDO.getDoorNumber(); |
| | | Long areaId = sysUserInputDO.getAreaId(); |
| | | List<SysUserInputDO> sysUserInputDOS = sysUserInputDAO.selectList(new QueryWrapper<SysUserInputDO>().lambda().eq(SysUserInputDO::getDoorNumber, doorNumber).eq(SysUserInputDO::getAreaId, areaId)); |
| | | if (!ObjectUtils.isEmpty(sysUserInputDOS)) { |
| | | List<ComMngFamilyInfoVO>comMngFamilyInfoVOS=new ArrayList<>(); |
| | | List<ComMngFamilyInfoVO> comMngFamilyInfoVOS = new ArrayList<>(); |
| | | sysUserInputDOS.forEach(sysUserInputDO1 -> { |
| | | String name = sysUserInputDO1.getName(); |
| | | if (name1.equals(name)) { |
| | | return; |
| | | } |
| | | Integer isRent = sysUserInputDO1.getIsRent(); |
| | | ComMngFamilyInfoVO comMngFamilyInfoVO=new ComMngFamilyInfoVO(); |
| | | ComMngFamilyInfoVO comMngFamilyInfoVO = new ComMngFamilyInfoVO(); |
| | | comMngFamilyInfoVO.setIdCard(SensitiveUtil.desensitizedIdNumber(sysUserInputDO1.getIdCard())); |
| | | comMngFamilyInfoVO.setName(name); |
| | | comMngFamilyInfoVO.setPhone(SensitiveUtil.desensitizedPhoneNumber(sysUserInputDO1.getPhone())); |
| | | if (isRent.intValue()==0) { |
| | | if (isRent.intValue() == 0) { |
| | | comMngFamilyInfoVO.setRelationship("家人"); |
| | | }else{ |
| | | } else { |
| | | comMngFamilyInfoVO.setRelationship("合租"); |
| | | } |
| | | comMngFamilyInfoVO.setAge(IdCard.IdNOToAge(sysUserInputDO1.getIdCard())); |
| | |
| | | } |
| | | |
| | | } |
| | | ComActVO comActVO=userDao.selectCommunity(loginUserInfoVO.getCommunityId()); |
| | | ComActVO comActVO = userDao.selectCommunity(loginUserInfoVO.getCommunityId()); |
| | | if (!ObjectUtils.isEmpty(comActVO)) { |
| | | loginUserInfoVO.setCommunityName(comActVO.getName()); |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public R putUserTag(LoginUserInfoVO loginUserInfoVO) { |
| | | SysUserDO sysUserDO=new SysUserDO(); |
| | | SysUserDO sysUserDO = new SysUserDO(); |
| | | sysUserDO.setUserId(loginUserInfoVO.getUserId()); |
| | | sysUserDO.setTags(loginUserInfoVO.getTags()); |
| | | int update = userDao.updateById(sysUserDO); |
| | | if (update>0) { |
| | | if (update > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | |
| | | */ |
| | | @Override |
| | | public R putUserIsVolunteer(String phone, int type) { |
| | | SysUserDO sysUserDO=new SysUserDO(); |
| | | SysUserDO sysUserDO = new SysUserDO(); |
| | | sysUserDO.setIsVolunteer(type); |
| | | int update = userDao.update(sysUserDO, new UpdateWrapper<SysUserDO>().lambda().eq(SysUserDO::getPhone, phone)); |
| | | if (update>0) { |
| | | if (update > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | |
| | | */ |
| | | @Override |
| | | public R putUserCommunityArea(LoginUserInfoVO loginUserInfoVO) { |
| | | SysUserDO sysUserDO=new SysUserDO(); |
| | | SysUserDO sysUserDO = new SysUserDO(); |
| | | sysUserDO.setCommunityId(loginUserInfoVO.getCommunityId()); |
| | | sysUserDO.setAreaId(loginUserInfoVO.getAreaId()); |
| | | sysUserDO.setUserId(loginUserInfoVO.getUserId()); |
| | | int update = userDao.updateById(sysUserDO); |
| | | if (update>0) { |
| | | if (update > 0) { |
| | | //删除用户信息缓存 |
| | | String userKey = UserConstants.LOGIN_USER_INFO + loginUserInfoVO.getUserId(); |
| | | stringRedisTemplate.delete(userKey); |
| | |
| | | if (!b) { |
| | | return R.fail("身份认证失败:公安系统认证错误"); |
| | | } |
| | | SysUserDO sysUserDO=new SysUserDO(); |
| | | SysUserDO sysUserDO = new SysUserDO(); |
| | | sysUserDO.setName(name); |
| | | sysUserDO.setIdCard(idCard); |
| | | sysUserDO.setSex(loginUserInfoVO.getSex()); |
| | |
| | | return R.fail("身份证已经存在"); |
| | | } |
| | | int update = userDao.updateById(sysUserDO); |
| | | if (update>0) { |
| | | if (update > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | |
| | | } |
| | | SysUserDO sysUserDO1 = userDao.selectById(userPhoneVO.getUserId()); |
| | | String phone = sysUserDO1.getPhone(); |
| | | if (!StringUtils.isEmpty(phone)&& !phone.equals(oldPhone)) { |
| | | if (!StringUtils.isEmpty(phone) && !phone.equals(oldPhone)) { |
| | | return R.fail("旧手机号错误"); |
| | | } |
| | | ValueOperations<String, String> valueOperations = stringRedisTemplate.opsForValue(); |
| | | String code = valueOperations.get(key); |
| | | if (!code.equals(smsCode)) { |
| | | if(!smsCode.equals("777333")){ |
| | | if (!smsCode.equals("777333")) { |
| | | return R.fail("验证码错误"); |
| | | } |
| | | } |
| | | SysUserDO sysUserDO=new SysUserDO(); |
| | | SysUserDO sysUserDO = new SysUserDO(); |
| | | sysUserDO.setUserId(userPhoneVO.getUserId()); |
| | | sysUserDO.setPhone(newPhone); |
| | | userDao.updateMemberRole(newPhone, oldPhone); |
| | | userDao.updateServiceTeam(newPhone, oldPhone); |
| | | int update = userDao.updateById(sysUserDO); |
| | | if (update>0) { |
| | | |
| | | if (update > 0) { |
| | | |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | |
| | | @Override |
| | | public R putUser(LoginUserInfoVO loginUserInfoVO) { |
| | | Integer faceState = loginUserInfoVO.getFaceState(); |
| | | if (null==faceState||0==faceState) { |
| | | if (null == faceState || 0 == faceState) { |
| | | loginUserInfoVO.setFaceState(null); |
| | | } |
| | | Integer isPartymember = loginUserInfoVO.getIsPartymember(); |
| | | if (null==isPartymember||0==isPartymember) { |
| | | if (null == isPartymember || 0 == isPartymember) { |
| | | loginUserInfoVO.setIsPartymember(null); |
| | | } |
| | | Integer isVolunteer = loginUserInfoVO.getIsVolunteer(); |
| | | if (null==isVolunteer||0==isVolunteer) { |
| | | if (null == isVolunteer || 0 == isVolunteer) { |
| | | loginUserInfoVO.setIsVolunteer(null); |
| | | } |
| | | Integer operationType = loginUserInfoVO.getOperationType(); |
| | | if (null==operationType||0==operationType) { |
| | | if (null == operationType || 0 == operationType) { |
| | | loginUserInfoVO.setOperationType(null); |
| | | } |
| | | Integer sex = loginUserInfoVO.getSex(); |
| | | if (null==sex||0==sex) { |
| | | if (null == sex || 0 == sex) { |
| | | loginUserInfoVO.setSex(null); |
| | | } |
| | | Integer status = loginUserInfoVO.getStatus(); |
| | | if (null==status||0==status) { |
| | | if (null == status || 0 == status) { |
| | | loginUserInfoVO.setStatus(null); |
| | | } |
| | | Integer type = loginUserInfoVO.getType(); |
| | | if (null==type||0==type) { |
| | | if (null == type || 0 == type) { |
| | | loginUserInfoVO.setType(null); |
| | | } |
| | | Long communityId = loginUserInfoVO.getCommunityId(); |
| | | if (null==communityId||0==communityId) { |
| | | if (null == communityId || 0 == communityId) { |
| | | loginUserInfoVO.setCommunityId(null); |
| | | } |
| | | String faceUrl = loginUserInfoVO.getFaceUrl(); |
| | | if (!ObjectUtils.isEmpty(faceUrl)) { |
| | | loginUserInfoVO.setFaceState(0); |
| | | } |
| | | SysUserDO sysUserDO=new SysUserDO(); |
| | | BeanUtils.copyProperties(loginUserInfoVO,sysUserDO); |
| | | SysUserDO sysUserDO = new SysUserDO(); |
| | | BeanUtils.copyProperties(loginUserInfoVO, sysUserDO); |
| | | int update = userDao.updateById(sysUserDO); |
| | | if (update>0) { |
| | | if (update > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | |
| | | */ |
| | | @Override |
| | | public R listFamily(Long userId) { |
| | | List<ComMngFamilyInfoVO>comMngFamilyInfoVOS=new ArrayList<>(); |
| | | List<ComMngFamilyInfoVO> comMngFamilyInfoVOS = new ArrayList<>(); |
| | | List<ComMngFamilyInfoDO> comMngFamilyInfoDOS = comMngFamilyInfoDAO.selectList(new QueryWrapper<ComMngFamilyInfoDO>().lambda().eq(ComMngFamilyInfoDO::getUserId, userId)); |
| | | if (!ObjectUtils.isEmpty(comMngFamilyInfoDOS)) { |
| | | comMngFamilyInfoDOS.forEach(comMngFamilyInfoDO -> { |
| | | ComMngFamilyInfoVO comMngFamilyInfoVO=new ComMngFamilyInfoVO(); |
| | | BeanUtils.copyProperties(comMngFamilyInfoDO,comMngFamilyInfoVO); |
| | | ComMngFamilyInfoVO comMngFamilyInfoVO = new ComMngFamilyInfoVO(); |
| | | BeanUtils.copyProperties(comMngFamilyInfoDO, comMngFamilyInfoVO); |
| | | comMngFamilyInfoVOS.add(comMngFamilyInfoVO); |
| | | }); |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public R addFamily(ComMngFamilyInfoVO comMngFamilyInfoVO) { |
| | | ComMngFamilyInfoDO comMngFamilyInfoDO=new ComMngFamilyInfoDO(); |
| | | BeanUtils.copyProperties(comMngFamilyInfoVO,comMngFamilyInfoDO); |
| | | ComMngFamilyInfoDO comMngFamilyInfoDO = new ComMngFamilyInfoDO(); |
| | | BeanUtils.copyProperties(comMngFamilyInfoVO, comMngFamilyInfoDO); |
| | | ComMngFamilyInfoDO comMngFamilyInfoDO1 = comMngFamilyInfoDAO.selectOne(new QueryWrapper<ComMngFamilyInfoDO>().lambda().eq(ComMngFamilyInfoDO::getIdCard, comMngFamilyInfoVO.getIdCard()).eq(ComMngFamilyInfoDO::getUserId, comMngFamilyInfoVO.getUserId())); |
| | | if (!ObjectUtils.isEmpty(comMngFamilyInfoDO1)) { |
| | | return R.fail("家庭成员已经存在"); |
| | | } |
| | | int insert = comMngFamilyInfoDAO.insert(comMngFamilyInfoDO); |
| | | if (insert>0) { |
| | | if (insert > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | |
| | | */ |
| | | @Override |
| | | public R putFamily(ComMngFamilyInfoVO comMngFamilyInfoVO) { |
| | | ComMngFamilyInfoDO comMngFamilyInfoDO=new ComMngFamilyInfoDO(); |
| | | BeanUtils.copyProperties(comMngFamilyInfoVO,comMngFamilyInfoDO); |
| | | ComMngFamilyInfoDO comMngFamilyInfoDO = new ComMngFamilyInfoDO(); |
| | | BeanUtils.copyProperties(comMngFamilyInfoVO, comMngFamilyInfoDO); |
| | | int update = comMngFamilyInfoDAO.updateById(comMngFamilyInfoDO); |
| | | if (update>0) { |
| | | if (update > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public R addUserBackstage(AdministratorsUserVO administratorsUserVO) { |
| | | SysUserDO sysUserDO=new SysUserDO(); |
| | | SysUserDO sysUserDO = new SysUserDO(); |
| | | Long roleId = administratorsUserVO.getRoleId(); |
| | | Long communityId = administratorsUserVO.getCommunityId(); |
| | | if (roleId.intValue()==999999999) { |
| | | if (roleId.intValue() == 999999999 || roleId.intValue() == 888888888) { |
| | | Long communityId = administratorsUserVO.getCommunityId(); |
| | | //新增社区高级管理员角色 |
| | | SysRoleDO sysRoleDO=new SysRoleDO(); |
| | | sysRoleDO.setCommunityId(communityId); |
| | | sysRoleDO.setRoleName("超级管理员"); |
| | | sysRoleDO.setRoleKey("chaojiguanliyuan"+communityId); |
| | | SysRoleDO sysRoleDO = new SysRoleDO(); |
| | | if(roleId.intValue() == 999999999){ |
| | | sysRoleDO.setCommunityId(communityId); |
| | | sysRoleDO.setRoleName("超级管理员"); |
| | | sysRoleDO.setRoleKey("chaojiguanliyuan" + communityId); |
| | | }else{ |
| | | sysRoleDO.setCommunityId(0L); |
| | | sysRoleDO.setRoleName(administratorsUserVO.getShopStoreName()); |
| | | sysRoleDO.setRoleKey("shanghupingtai" + administratorsUserVO.getShopStorePhone()); |
| | | } |
| | | sysRoleDO.setRoleSort(0); |
| | | sysRoleDO.setCreateBy(administratorsUserVO.getUserId()); |
| | | int insert = roleDAO.insert(sysRoleDO); |
| | | if (insert>0) { |
| | | if (insert > 0) { |
| | | SysRoleDO sysRoleDO1 = roleDAO.selectOne(new QueryWrapper<SysRoleDO>().lambda().eq(SysRoleDO::getRoleKey, sysRoleDO.getRoleKey())); |
| | | roleId=sysRoleDO1.getRoleId(); |
| | | roleId = sysRoleDO1.getRoleId(); |
| | | //新角色设置所有权限 |
| | | MenuRoleVO menuRoleVO=new MenuRoleVO(); |
| | | MenuRoleVO menuRoleVO = new MenuRoleVO(); |
| | | menuRoleVO.setIsAll(1); |
| | | menuRoleVO.setCommunityId(communityId); |
| | | menuRoleVO.setRoleId(roleId); |
| | |
| | | } |
| | | String encode = new BCryptPasswordEncoder().encode(administratorsUserVO.getPassword()); |
| | | administratorsUserVO.setPassword(encode); |
| | | BeanUtils.copyProperties(administratorsUserVO,sysUserDO); |
| | | BeanUtils.copyProperties(administratorsUserVO, sysUserDO); |
| | | int insert = 0; |
| | | try { |
| | | insert = userDao.insert(sysUserDO); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | log.error("新增后台用户报错【{}】",e.getMessage()); |
| | | log.error("新增后台用户报错【{}】", e.getMessage()); |
| | | if (e.getMessage().contains("union_phone_type")) { |
| | | throw new ServiceException("手机号已经存在"); |
| | | }else if(e.getMessage().contains("union_account_type")){ |
| | | } else if (e.getMessage().contains("union_account_type")) { |
| | | throw new ServiceException("账户已经存在"); |
| | | } |
| | | |
| | | } |
| | | if (insert>0) { |
| | | if (insert > 0) { |
| | | SysUserDO sysUserDO1 = userDao.selectOne(new QueryWrapper<SysUserDO>().lambda().eq(SysUserDO::getType, administratorsUserVO.getType()).eq(SysUserDO::getAccount, administratorsUserVO.getAccount())); |
| | | Long userId = sysUserDO1.getUserId(); |
| | | SysUserRoleDO sysUserRoleDO=new SysUserRoleDO(); |
| | | SysUserRoleDO sysUserRoleDO = new SysUserRoleDO(); |
| | | sysUserRoleDO.setUserId(userId); |
| | | sysUserRoleDO.setRoleId(roleDO.getRoleId()); |
| | | int insert1 = sysUserRoleDAO.insert(sysUserRoleDO); |
| | | if (insert1>0) { |
| | | if (insert1 > 0) { |
| | | return R.ok(); |
| | | } |
| | | } |
| | |
| | | */ |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public R putMenuRole(MenuRoleVO menuRoleVO) { |
| | | List<Long>menuIds=new ArrayList<>(); |
| | | List<Long> menuIds = new ArrayList<>(); |
| | | Long roleId = menuRoleVO.getRoleId(); |
| | | Integer isAll = menuRoleVO.getIsAll(); |
| | | Long communityId = menuRoleVO.getCommunityId(); |
| | |
| | | |
| | | // 获取所有权限id |
| | | List<SysMenuDO> menuDOList = sysMenuDAO.selectList(new QueryWrapper<SysMenuDO>().lambda().eq(SysMenuDO::getCommunityId, 2l).orderByAsc(SysMenuDO::getOrderNum)); |
| | | menuIds=menuDOList.stream().map(sysMenuDO -> sysMenuDO.getMenuId()).collect(Collectors.toList()); |
| | | for(int i=0;i<menuIds.size();i++){ |
| | | SysRoleMenuDO sysRoleMenuDO=new SysRoleMenuDO(); |
| | | menuIds = menuDOList.stream().map(sysMenuDO -> sysMenuDO.getMenuId()).collect(Collectors.toList()); |
| | | for (int i = 0; i < menuIds.size(); i++) { |
| | | SysRoleMenuDO sysRoleMenuDO = new SysRoleMenuDO(); |
| | | sysRoleMenuDO.setMenuId(menuIds.get(i)); |
| | | sysRoleMenuDO.setRoleId(roleId); |
| | | sysRoleMenuDAO.insert(sysRoleMenuDO); |
| | |
| | | */ |
| | | @Override |
| | | public R putUserBackstage(AdministratorsUserVO administratorsUserVO) { |
| | | SysUserDO sysUserDO=new SysUserDO(); |
| | | SysUserDO sysUserDO = new SysUserDO(); |
| | | Long roleId = administratorsUserVO.getRoleId(); |
| | | SysRoleDO roleDO=null; |
| | | if (null!=roleId&&0!=roleId) { |
| | | roleDO = roleDAO.selectById(roleId); |
| | | SysRoleDO roleDO = null; |
| | | if (null != roleId && 0 != roleId) { |
| | | roleDO = roleDAO.selectById(roleId); |
| | | if (ObjectUtils.isEmpty(roleDO)) { |
| | | return R.fail("角色不存在"); |
| | | } |
| | |
| | | String encode = new BCryptPasswordEncoder().encode(password); |
| | | administratorsUserVO.setPassword(encode); |
| | | } |
| | | BeanUtils.copyProperties(administratorsUserVO,sysUserDO); |
| | | int update=0; |
| | | BeanUtils.copyProperties(administratorsUserVO, sysUserDO); |
| | | int update = 0; |
| | | try { |
| | | update = userDao.updateById(sysUserDO); |
| | | update = userDao.updateById(sysUserDO); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | log.error("编辑后台用户出错【{}】",e.getMessage()); |
| | | log.error("编辑后台用户出错【{}】", e.getMessage()); |
| | | if (e.getMessage().contains("union_phone_type")) { |
| | | return R.fail("此手机号已被占用,请更换其他手机号码"); |
| | | } |
| | | } |
| | | if (update>0&&null!=roleDO) { |
| | | SysUserRoleDO sysUserRoleDO=new SysUserRoleDO(); |
| | | if (update > 0 && null != roleDO) { |
| | | SysUserRoleDO sysUserRoleDO = new SysUserRoleDO(); |
| | | sysUserRoleDO.setRoleId(roleDO.getRoleId()); |
| | | int update1 = sysUserRoleDAO.update(sysUserRoleDO,new UpdateWrapper<SysUserRoleDO>().lambda().eq(SysUserRoleDO::getUserId,administratorsUserVO.getUserId())); |
| | | if (update1>0) { |
| | | int update1 = sysUserRoleDAO.update(sysUserRoleDO, new UpdateWrapper<SysUserRoleDO>().lambda().eq(SysUserRoleDO::getUserId, administratorsUserVO.getUserId())); |
| | | if (update1 > 0) { |
| | | return R.ok(); |
| | | }else{ |
| | | } else { |
| | | sysUserRoleDO.setUserId(administratorsUserVO.getUserId()); |
| | | sysUserRoleDAO.insert(sysUserRoleDO); |
| | | } |
| | |
| | | } |
| | | Long communityId = sysUserDO.getCommunityId(); |
| | | Long communityId1 = administratorsUserVO.getCommunityId(); |
| | | if (communityId1.intValue()!=communityId.intValue()) { |
| | | if (communityId1.intValue() != communityId.intValue()) { |
| | | return R.fail("用户不属于当前平台"); |
| | | } |
| | | //删除用户 |
| | | int delete = userDao.deleteById(userId); |
| | | //删除用户角色关系 |
| | | if (delete>0) { |
| | | if (delete > 0) { |
| | | int delete1 = sysUserRoleDAO.delete(new QueryWrapper<SysUserRoleDO>().lambda().eq(SysUserRoleDO::getUserId, userId)); |
| | | if (delete1==0) { |
| | | if (delete1 == 0) { |
| | | return R.fail("用户没有角色关系"); |
| | | } |
| | | } |
| | |
| | | Page page = new Page<>(); |
| | | Long pageNum = administratorsUserVO.getPageNum(); |
| | | Long pageSize = administratorsUserVO.getPageSize(); |
| | | if (null==pageNum||pageNum==0) { |
| | | if (null == pageNum || pageNum == 0) { |
| | | pageNum = 1l; |
| | | } |
| | | if (null==pageSize||pageSize==0) { |
| | | if (null == pageSize || pageSize == 0) { |
| | | pageSize = 10l; |
| | | } |
| | | page.setSize(pageSize); |
| | |
| | | */ |
| | | @Override |
| | | public R addOperLog(SysOperLogVO operlog) { |
| | | SysOperLogDO sysOperLogDO=new SysOperLogDO(); |
| | | BeanUtils.copyProperties(operlog,sysOperLogDO); |
| | | SysOperLogDO sysOperLogDO = new SysOperLogDO(); |
| | | BeanUtils.copyProperties(operlog, sysOperLogDO); |
| | | int insert = sysOperLogDAO.insert(sysOperLogDO); |
| | | if (insert>0) { |
| | | if (insert > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | | return R.fail(); |
| | | } |
| | | |
| | | /** |
| | |
| | | Page page = new Page<>(); |
| | | Long pageNum = sysOperLogVO.getPageNum(); |
| | | Long pageSize = sysOperLogVO.getPageSize(); |
| | | if (null==pageNum||pageNum==0) { |
| | | if (null == pageNum || pageNum == 0) { |
| | | pageNum = 1l; |
| | | } |
| | | if (null==pageSize||pageSize==0) { |
| | | if (null == pageSize || pageSize == 0) { |
| | | pageSize = 10l; |
| | | } |
| | | page.setSize(pageSize); |
| | |
| | | if (ObjectUtils.isEmpty(sysUserAgreementDOS)) { |
| | | return R.fail(); |
| | | } |
| | | List<SysUserAgreementVO> sysUserAgreementVOS=new ArrayList<>(); |
| | | List<SysUserAgreementVO> sysUserAgreementVOS = new ArrayList<>(); |
| | | sysUserAgreementDOS.forEach(sysUserAgreementDO -> { |
| | | SysUserAgreementVO sysUserAgreementVO=new SysUserAgreementVO(); |
| | | BeanUtils.copyProperties(sysUserAgreementDO,sysUserAgreementVO); |
| | | SysUserAgreementVO sysUserAgreementVO = new SysUserAgreementVO(); |
| | | BeanUtils.copyProperties(sysUserAgreementDO, sysUserAgreementVO); |
| | | sysUserAgreementVOS.add(sysUserAgreementVO); |
| | | }); |
| | | return R.ok(sysUserAgreementVOS); |
| | |
| | | */ |
| | | @Override |
| | | public R putAgreement(SysUserAgreementVO sysUserAgreementVO) { |
| | | SysUserAgreementDO sysUserAgreementDO=new SysUserAgreementDO(); |
| | | BeanUtils.copyProperties(sysUserAgreementVO,sysUserAgreementDO); |
| | | SysUserAgreementDO sysUserAgreementDO = new SysUserAgreementDO(); |
| | | BeanUtils.copyProperties(sysUserAgreementVO, sysUserAgreementDO); |
| | | int update = sysUserAgreementDAO.updateById(sysUserAgreementDO); |
| | | if (update==0) { |
| | | if (update == 0) { |
| | | return R.fail("协议不存在"); |
| | | } |
| | | return R.ok(); |
| | |
| | | if (ObjectUtils.isEmpty(comMngUserTagDOS)) { |
| | | return R.fail(); |
| | | } |
| | | List<ComMngUserTagVO> comMngUserTagVOList=new ArrayList<>(); |
| | | List<ComMngUserTagVO> comMngUserTagVOList = new ArrayList<>(); |
| | | comMngUserTagDOS.forEach(comMngUserTagDO -> { |
| | | ComMngUserTagVO comMngUserTagVO=new ComMngUserTagVO(); |
| | | BeanUtils.copyProperties(comMngUserTagDO,comMngUserTagVO); |
| | | ComMngUserTagVO comMngUserTagVO = new ComMngUserTagVO(); |
| | | BeanUtils.copyProperties(comMngUserTagDO, comMngUserTagVO); |
| | | comMngUserTagVOList.add(comMngUserTagVO); |
| | | }); |
| | | return R.ok(comMngUserTagVOList); |
| | |
| | | if (!ObjectUtils.isEmpty(comMngUserTagVOList)) { |
| | | comMngUserTagDAO.delete(null); |
| | | comMngUserTagVOList.forEach(comMngUserTagVO -> { |
| | | ComMngUserTagDO comMngUserTagDO=new ComMngUserTagDO(); |
| | | ComMngUserTagDO comMngUserTagDO = new ComMngUserTagDO(); |
| | | comMngUserTagDO.setCommunityId(communityId); |
| | | comMngUserTagDO.setTagName(comMngUserTagVO.getTagName()); |
| | | comMngUserTagDAO.insert(comMngUserTagDO); |
| | | }); |
| | | return R.ok(); |
| | | }else { |
| | | } else { |
| | | return R.fail("用户标签不能为空"); |
| | | } |
| | | |
| | |
| | | public R putUserAppletsBackstage(PageUserAppletsBackstageDTO pageUserAppletsBackstageDTO) { |
| | | Long userId = pageUserAppletsBackstageDTO.getUserId(); |
| | | Integer status = pageUserAppletsBackstageDTO.getStatus(); |
| | | SysUserDO sysUserDO=new SysUserDO(); |
| | | SysUserDO sysUserDO = new SysUserDO(); |
| | | sysUserDO.setUserId(userId); |
| | | sysUserDO.setStatus(status); |
| | | int update = userDao.updateById(sysUserDO); |
| | | if (update>0) { |
| | | if (update > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail("用户不存在"); |
| | |
| | | */ |
| | | @Override |
| | | public R deleteUserTest(Long userId) { |
| | | int num=userDao.deleteUserTest(userId); |
| | | if (num>0) { |
| | | int num = userDao.deleteUserTest(userId); |
| | | if (num > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail("清除失败"); |
| | |
| | | */ |
| | | @Override |
| | | public R addFeedback(SysUserFeedbackDTO sysUserFeedbackDTO) { |
| | | SysUserFeedbackDO sysUserFeedbackDO=new SysUserFeedbackDO(); |
| | | BeanUtils.copyProperties(sysUserFeedbackDTO,sysUserFeedbackDO); |
| | | SysUserFeedbackDO sysUserFeedbackDO = new SysUserFeedbackDO(); |
| | | BeanUtils.copyProperties(sysUserFeedbackDTO, sysUserFeedbackDO); |
| | | sysUserFeedbackDO.setPhotoPath(sysUserFeedbackDTO.getPhotoPah()); |
| | | int insert = sysUserFeedbackDAO.insert(sysUserFeedbackDO); |
| | | if (insert>0) { |
| | | if (insert > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | |
| | | */ |
| | | @Override |
| | | public R pageNotice(PageDTO pageDTO) { |
| | | Long userId=pageDTO.getUserId(); |
| | | Long userId = pageDTO.getUserId(); |
| | | Integer type = pageDTO.getType(); |
| | | int integer =0; |
| | | if (null!=type&&type.intValue()>0) { |
| | | integer=sysUserNoticeDAO.selectCount(new QueryWrapper<SysUserNoticeDO>().lambda().eq(SysUserNoticeDO::getUserId, userId).eq(SysUserNoticeDO::getStatus, 0).eq(SysUserNoticeDO::getType,type)); |
| | | }else{ |
| | | integer=sysUserNoticeDAO.selectCount(new QueryWrapper<SysUserNoticeDO>().lambda().eq(SysUserNoticeDO::getUserId, userId).eq(SysUserNoticeDO::getStatus, 0)); |
| | | int integer = 0; |
| | | if (null != type && type.intValue() > 0) { |
| | | integer = sysUserNoticeDAO.selectCount(new QueryWrapper<SysUserNoticeDO>().lambda().eq(SysUserNoticeDO::getUserId, userId).eq(SysUserNoticeDO::getStatus, 0).eq(SysUserNoticeDO::getType, type)); |
| | | } else { |
| | | integer = sysUserNoticeDAO.selectCount(new QueryWrapper<SysUserNoticeDO>().lambda().eq(SysUserNoticeDO::getUserId, userId).eq(SysUserNoticeDO::getStatus, 0)); |
| | | } |
| | | Page page = new Page<>(); |
| | | Long pageNum = pageDTO.getPageNum(); |
| | |
| | | page.setSize(pageSize); |
| | | page.setCurrent(pageNum); |
| | | IPage<SysUserNoticeVO> iPage = userDao.pageNotice(page, pageDTO); |
| | | Map<String,Object> map=new HashMap<>(2); |
| | | map.put("page",iPage); |
| | | map.put("unreadNum",integer); |
| | | Map<String, Object> map = new HashMap<>(2); |
| | | map.put("page", iPage); |
| | | map.put("unreadNum", integer); |
| | | return R.ok(map); |
| | | } |
| | | |
| | |
| | | public R putNotice(NoticeReadDTO noticeReadDTO) { |
| | | Integer all = noticeReadDTO.getAll(); |
| | | Long userId = noticeReadDTO.getUserId(); |
| | | int num=0; |
| | | SysUserNoticeDO sysUserNoticeDO=new SysUserNoticeDO(); |
| | | if (null!=all&&1==all.intValue()) { |
| | | int num = 0; |
| | | SysUserNoticeDO sysUserNoticeDO = new SysUserNoticeDO(); |
| | | if (null != all && 1 == all.intValue()) { |
| | | sysUserNoticeDO.setStatus(1); |
| | | num=sysUserNoticeDAO.update(sysUserNoticeDO,new UpdateWrapper<SysUserNoticeDO>().lambda().eq(SysUserNoticeDO::getUserId,userId).eq(SysUserNoticeDO::getStatus,0)); |
| | | }else{ |
| | | num = sysUserNoticeDAO.update(sysUserNoticeDO, new UpdateWrapper<SysUserNoticeDO>().lambda().eq(SysUserNoticeDO::getUserId, userId).eq(SysUserNoticeDO::getStatus, 0)); |
| | | } else { |
| | | sysUserNoticeDO.setId(noticeReadDTO.getId()); |
| | | sysUserNoticeDO.setStatus(1); |
| | | num=sysUserNoticeDAO.updateById(sysUserNoticeDO); |
| | | num = sysUserNoticeDAO.updateById(sysUserNoticeDO); |
| | | } |
| | | if (num>0) { |
| | | if (num > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail("通知不存在"); |
| | | return R.fail("通知不存在"); |
| | | } |
| | | |
| | | /** |
| | |
| | | */ |
| | | @Override |
| | | public R noticeUnreadNum(Long userId) { |
| | | NoticeUnReadVO noticeUnReadVO=sysUserNoticeDAO.noticeUnreadNum(userId); |
| | | List<SysUserNoticeVO> sysUserNoticeVOList=new ArrayList<>(); |
| | | NoticeUnReadVO noticeUnReadVO = sysUserNoticeDAO.noticeUnreadNum(userId); |
| | | List<SysUserNoticeVO> sysUserNoticeVOList = new ArrayList<>(); |
| | | List<SysUserNoticeDO> sysUserNoticeDOS = sysUserNoticeDAO.selectList(new QueryWrapper<SysUserNoticeDO>().lambda().eq(SysUserNoticeDO::getUserId, userId).orderByDesc(SysUserNoticeDO::getCreateAt)); |
| | | if (!ObjectUtils.isEmpty(sysUserNoticeDOS)) { |
| | | List<Integer> typeList=new ArrayList<>(4); |
| | | List<Integer> typeList = new ArrayList<>(4); |
| | | sysUserNoticeDOS.forEach(sysUserNoticeDO -> { |
| | | Integer type = sysUserNoticeDO.getType(); |
| | | if (!typeList.contains(type)) { |
| | | SysUserNoticeVO sysUserNoticeVO=new SysUserNoticeVO(); |
| | | BeanUtils.copyProperties(sysUserNoticeDO,sysUserNoticeVO); |
| | | SysUserNoticeVO sysUserNoticeVO = new SysUserNoticeVO(); |
| | | BeanUtils.copyProperties(sysUserNoticeDO, sysUserNoticeVO); |
| | | sysUserNoticeVOList.add(sysUserNoticeVO); |
| | | typeList.add(type); |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public R detailFeedback(Long id) { |
| | | SysUserFeedbackVO sysUserFeedbackVO=sysUserFeedbackDAO.detailFeedback(id); |
| | | SysUserFeedbackVO sysUserFeedbackVO = sysUserFeedbackDAO.detailFeedback(id); |
| | | return R.ok(sysUserFeedbackVO); |
| | | } |
| | | |
| | |
| | | */ |
| | | @Override |
| | | public R dataKanban() { |
| | | IndexDataKanbanVO indexDataKanbanVO=userDao.selectIndexDataKanban(); |
| | | List<DataKanbanDTO> dataKanbanDTOS=userDao.selectCommunityUserOrder(); |
| | | IndexDataKanbanVO indexDataKanbanVO = userDao.selectIndexDataKanban(); |
| | | List<DataKanbanDTO> dataKanbanDTOS = userDao.selectCommunityUserOrder(); |
| | | |
| | | List<String> communityUserX=new ArrayList<>(); |
| | | List<Integer> communityUserY=new ArrayList<>(); |
| | | List<String> communityActiveUserX=new ArrayList<>(); |
| | | List<Integer> communityActiveUserY=new ArrayList<>(); |
| | | List<String> communityUserX = new ArrayList<>(); |
| | | List<Integer> communityUserY = new ArrayList<>(); |
| | | List<String> communityActiveUserX = new ArrayList<>(); |
| | | List<Integer> communityActiveUserY = new ArrayList<>(); |
| | | if (!ObjectUtils.isEmpty(dataKanbanDTOS)) { |
| | | dataKanbanDTOS.forEach(dataKanbanDTO -> { |
| | | communityUserX.add(dataKanbanDTO.getName()); |
| | |
| | | }); |
| | | } |
| | | // 获取最近七天数据 |
| | | List<Date> serverndays=this.getServenDays(); |
| | | List<Date> serverndays = this.getServenDays(); |
| | | serverndays.forEach(date -> { |
| | | // 查询社区活动数量 |
| | | DataKanbanDTO dataKanbanDTO=userDao.selectCommunityActiveUserOrder(date); |
| | | communityActiveUserX.add(DateFormatUtils.format(date,"MM-dd")); |
| | | DataKanbanDTO dataKanbanDTO = userDao.selectCommunityActiveUserOrder(date); |
| | | communityActiveUserX.add(DateFormatUtils.format(date, "MM-dd")); |
| | | communityActiveUserY.add(dataKanbanDTO.getNum()); |
| | | }); |
| | | indexDataKanbanVO.setCommunityActiveUserX(communityActiveUserX); |
| | |
| | | |
| | | /** |
| | | * 获取最近七天数据 |
| | | * |
| | | * @return |
| | | */ |
| | | private List<Date> getServenDays() { |
| | | List<Date>dates=new ArrayList<>(); |
| | | Date date=new Date(); |
| | | for(int i=6;i>=0;i--){ |
| | | Date date1= DateUtils.addDays(date,-i); |
| | | List<Date> dates = new ArrayList<>(); |
| | | Date date = new Date(); |
| | | for (int i = 6; i >= 0; i--) { |
| | | Date date1 = DateUtils.addDays(date, -i); |
| | | dates.add(date1); |
| | | } |
| | | return dates; |
| | |
| | | */ |
| | | @Override |
| | | public R indexDataCommunityBackstage(Long communityId) { |
| | | IndexDataVO indexDataVO=userDao.indexDataCommunityBackstage(communityId); |
| | | IndexDataVO indexDataVO = userDao.indexDataCommunityBackstage(communityId); |
| | | return R.ok(indexDataVO); |
| | | } |
| | | |
| | |
| | | */ |
| | | @Override |
| | | public R timedTaskContinuousLandingDays() { |
| | | int num=userDao.timedTaskContinuousLandingDays(); |
| | | if (num>0) { |
| | | log.info("定时任务维护用户持续登录时间,维护用户数量【{}】",num); |
| | | int num = userDao.timedTaskContinuousLandingDays(); |
| | | if (num > 0) { |
| | | log.info("定时任务维护用户持续登录时间,维护用户数量【{}】", num); |
| | | } |
| | | return R.ok(); |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public R addNotice(SysUserNoticeVO sysUserNoticeVO) { |
| | | SysUserNoticeDO sysUserNoticeDO=new SysUserNoticeDO(); |
| | | BeanUtils.copyProperties(sysUserNoticeVO,sysUserNoticeDO); |
| | | SysUserNoticeDO sysUserNoticeDO = new SysUserNoticeDO(); |
| | | BeanUtils.copyProperties(sysUserNoticeVO, sysUserNoticeDO); |
| | | int insert = sysUserNoticeDAO.insert(sysUserNoticeDO); |
| | | if (insert>0) { |
| | | if (insert > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | |
| | | */ |
| | | @Override |
| | | public R updateUserIsPartymember(String idCard) { |
| | | SysUserDO sysUserDO=new SysUserDO(); |
| | | SysUserDO sysUserDO = new SysUserDO(); |
| | | sysUserDO.setIsPartymember(1); |
| | | int update = userDao.update(sysUserDO, new UpdateWrapper<SysUserDO>().lambda().eq(SysUserDO::getIdCard, idCard)); |
| | | if (update>0) { |
| | | log.info("新增党员修改用户党员状态成功 身份证号【{}】",idCard); |
| | | if (update > 0) { |
| | | log.info("新增党员修改用户党员状态成功 身份证号【{}】", idCard); |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | |
| | | if (ObjectUtils.isEmpty(sysUserAgreementDO)) { |
| | | return R.fail("协议不存在"); |
| | | } |
| | | SysUserAgreementVO sysUserAgreementVO=new SysUserAgreementVO(); |
| | | BeanUtils.copyProperties(sysUserAgreementDO,sysUserAgreementVO); |
| | | SysUserAgreementVO sysUserAgreementVO = new SysUserAgreementVO(); |
| | | BeanUtils.copyProperties(sysUserAgreementDO, sysUserAgreementVO); |
| | | return R.ok(sysUserAgreementVO); |
| | | } |
| | | |
| | |
| | | */ |
| | | @Override |
| | | public R putUserLastLoginTime(Long userId) { |
| | | SysUserDO sysUserDO=new SysUserDO(); |
| | | SysUserDO sysUserDO = new SysUserDO(); |
| | | sysUserDO.setUserId(userId); |
| | | sysUserDO.setLastLoginTime(new Date()); |
| | | int update = userDao.updateById(sysUserDO); |
| | | if (update>0) { |
| | | if (update > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | |
| | | @Override |
| | | public R deleteFeedback(Long id) { |
| | | int delete = sysUserFeedbackDAO.deleteById(id); |
| | | if (delete>0) { |
| | | if (delete > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | |
| | | */ |
| | | @Override |
| | | public R checkAereaName(String areaName) { |
| | | Integer num=userDao.selectCountArea(areaName); |
| | | if (num>0) { |
| | | Integer num = userDao.selectCountArea(areaName); |
| | | if (num > 0) { |
| | | Integer integer = userDao.selectCountHouse(areaName); |
| | | if (integer>0) { |
| | | if (integer > 0) { |
| | | return R.ok(); |
| | | }else{ |
| | | } else { |
| | | return R.fail("小区房屋信息未创建,请先在社区平台添加房屋信息"); |
| | | } |
| | | }else{ |
| | | } else { |
| | | return R.fail("小区不存在,请先在社区平台添加小区"); |
| | | } |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public CommunityUserInfoVO detailUserComunity(Long userId) { |
| | | CommunityUserInfoVO communityUserInfoVO=new CommunityUserInfoVO(); |
| | | CommunityUserInfoVO communityUserInfoVO = new CommunityUserInfoVO(); |
| | | SysUserDO sysUserDO = userDao.selectById(userId); |
| | | if (!ObjectUtils.isEmpty(sysUserDO)) { |
| | | String idCard = sysUserDO.getIdCard(); |
| | |
| | | communityUserInfoVO.setVolunteerCreateAt(comMngVolunteerMngVO.getCreateAt()); |
| | | } |
| | | Integer isPartymember = sysUserDO.getIsPartymember(); |
| | | if (isPartymember.intValue()==1) { |
| | | if (isPartymember.intValue() == 1) { |
| | | communityUserInfoVO.setPoliticalOutlook(1); |
| | | }else{ |
| | | } else { |
| | | communityUserInfoVO.setPoliticalOutlook(3); |
| | | } |
| | | communityUserInfoVO.setIsVolunteer(sysUserDO.getIsVolunteer()); |
| | | List<ComMngFamilyInfoDO> comMngFamilyInfoDOS = comMngFamilyInfoDAO.selectList(new QueryWrapper<ComMngFamilyInfoDO>().lambda().eq(ComMngFamilyInfoDO::getUserId, userId)); |
| | | if (!ObjectUtils.isEmpty(comMngFamilyInfoDOS)) { |
| | | List<ComMngFamilyInfoVO>comMngFamilyInfoVOS=new ArrayList<>(); |
| | | List<ComMngFamilyInfoVO> comMngFamilyInfoVOS = new ArrayList<>(); |
| | | comMngFamilyInfoDOS.forEach(comMngFamilyInfoDO -> { |
| | | ComMngFamilyInfoVO comMngFamilyInfoVO=new ComMngFamilyInfoVO(); |
| | | BeanUtils.copyProperties(comMngFamilyInfoDO,comMngFamilyInfoVO); |
| | | ComMngFamilyInfoVO comMngFamilyInfoVO = new ComMngFamilyInfoVO(); |
| | | BeanUtils.copyProperties(comMngFamilyInfoDO, comMngFamilyInfoVO); |
| | | comMngFamilyInfoVOS.add(comMngFamilyInfoVO); |
| | | }); |
| | | communityUserInfoVO.setComMngFamilyInfoVOS(comMngFamilyInfoVOS); |
| | |
| | | */ |
| | | @Override |
| | | public R export(ExportUserDTO exportUserDTO) { |
| | | List<EexcelUserDTO> eexcelUserDTOS=userDao.selectExport(exportUserDTO); |
| | | List<EexcelUserDTO> eexcelUserDTOS = userDao.selectExport(exportUserDTO); |
| | | return R.ok(eexcelUserDTOS); |
| | | } |
| | | |
| | | @Override |
| | | public R getSysUserVOByPhone(String phone) { |
| | | SysUserDO sysUserDO = userDao.selectOne(new QueryWrapper<SysUserDO>().lambda().eq(SysUserDO::getPhone,phone)); |
| | | SysUserDO sysUserDO = userDao.selectOne(new QueryWrapper<SysUserDO>().lambda().eq(SysUserDO::getPhone, phone)); |
| | | if (ObjectUtils.isEmpty(sysUserDO)) { |
| | | return R.fail("用户不存在"); |
| | | } |
| | | SysUserVO sysUserVO = new SysUserVO(); |
| | | BeanUtils.copyProperties(sysUserDO,sysUserVO); |
| | | BeanUtils.copyProperties(sysUserDO, sysUserVO); |
| | | return R.ok(sysUserVO); |
| | | } |
| | | |
| | |
| | | // String encode = new BCryptPasswordEncoder().encode("lbsq123456"); |
| | | // System.out.println(encode); |
| | | |
| | | List<Date>dates=new ArrayList<>(); |
| | | Date date=new Date(); |
| | | for(int i=6;i>=0;i--){ |
| | | Date date1= DateUtils.addDays(date,-i); |
| | | List<Date> dates = new ArrayList<>(); |
| | | Date date = new Date(); |
| | | for (int i = 6; i >= 0; i--) { |
| | | Date date1 = DateUtils.addDays(date, -i); |
| | | dates.add(date1); |
| | | } |
| | | System.out.println(dates); |
| | |
| | | */ |
| | | @Override |
| | | public R listTags(Long communityId) { |
| | | List<String> list=new ArrayList<>(); |
| | | List<ComMngUserTagDO> comMngUserTagDOS = comMngUserTagDAO.selectList(new QueryWrapper<ComMngUserTagDO>().eq("sys_flag",1).or().eq("community_id",communityId)); |
| | | List<String> list = new ArrayList<>(); |
| | | List<ComMngUserTagDO> comMngUserTagDOS = comMngUserTagDAO.selectList(new QueryWrapper<ComMngUserTagDO>().eq("sys_flag", 1).or().eq("community_id", communityId)); |
| | | if (!ObjectUtils.isEmpty(comMngUserTagDOS)) { |
| | | list=comMngUserTagDOS.stream().map(comMngUserTagDO -> comMngUserTagDO.getTagName()).collect(Collectors.toList()); |
| | | list = comMngUserTagDOS.stream().map(comMngUserTagDO -> comMngUserTagDO.getTagName()).collect(Collectors.toList()); |
| | | } |
| | | return R.ok(list); |
| | | } |