From b039abae18bbd3b94e9b995b4f274f6f0ec7fb91 Mon Sep 17 00:00:00 2001 From: manailin <261030956@qq.com> Date: 星期一, 13 九月 2021 14:58:28 +0800 Subject: [PATCH] [新增]将user 模块下dao层的sql 全部转化到xml 中执行。 --- springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java | 55 ++++++++++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 46 insertions(+), 9 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java index 4545a4c..49ed606 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java @@ -14,7 +14,6 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.ObjectUtils; -import org.springframework.util.StringUtils; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; @@ -458,8 +457,39 @@ IPage<AppletUserInfoVO> iPage = userDao.pageUser(new Page<>(userInfoVO.getPageNum(), userInfoVO.getPageSize()), userInfoVO); iPage.getRecords().forEach(record -> { - record.setPhone(SensitiveUtil.desensitizedPhoneNumber(record.getPhone())); +// record.setPhone(SensitiveUtil.desensitizedPhoneNumber(record.getPhone())); record.setIdCard(SensitiveUtil.desensitizedIdNumber(record.getIdCard())); + + if (StringUtils.isNotEmpty(record.getTags())) { + StringBuffer sb = new StringBuffer(); + sb.append(record.getTags() + ","); + if (record.getIsPartymember().equals(1)) { + if (!sb.toString().contains("党员")){ + sb.append("党员,"); + } + } + if (record.getIsVolunteer().equals(1)) { + if (!sb.toString().contains("志愿者")) { + sb.append("志愿者,"); + } + } + String tags = sb.toString(); + record.setTags(tags.substring(0, tags.length() - 1)); + }else { + StringBuffer sb = new StringBuffer(); + if (record.getIsPartymember().equals(1)) { + sb.append("党员,"); + } + if (record.getIsVolunteer().equals(1)) { + sb.append("志愿者,"); + } + String tags = sb.toString(); + if (tags.length() > 0) { + record.setTags(tags.substring(0, tags.length() - 1)); + } else { + record.setTags("无"); + } + } }); return R.ok(iPage); } @@ -564,8 +594,10 @@ public R putUserTag(LoginUserInfoVO loginUserInfoVO) { SysUserDO sysUserDO = new SysUserDO(); sysUserDO.setUserId(loginUserInfoVO.getUserId()); - sysUserDO.setTags(loginUserInfoVO.getTags()); - int update = userDao.updateById(sysUserDO); + if (StringUtils.isNotEmpty(loginUserInfoVO.getTags()) && !"无".equals(loginUserInfoVO.getTags())) { + sysUserDO.setTags(loginUserInfoVO.getTags()); + } + int update = userDao.putUserTag(sysUserDO); if (update > 0) { return R.ok(); } @@ -1293,7 +1325,7 @@ Long communityId = systemmanagementConfigVO.getCommunityId(); List<ComMngUserTagVO> comMngUserTagVOList = systemmanagementConfigVO.getComMngUserTagVOList(); if (!ObjectUtils.isEmpty(comMngUserTagVOList)) { - comMngUserTagDAO.delete(null); + comMngUserTagDAO.delete(new QueryWrapper<ComMngUserTagDO>().lambda().eq(ComMngUserTagDO::getCommunityId,communityId)); comMngUserTagVOList.forEach(comMngUserTagVO -> { ComMngUserTagDO comMngUserTagDO = new ComMngUserTagDO(); comMngUserTagDO.setCommunityId(communityId); @@ -1820,13 +1852,18 @@ * @return 标签集合 */ @Override - public R listTags(Long communityId) { + public R listTags() { List<String> list = new ArrayList<>(); List<ComMngUserTagDO> comMngUserTagDOS = comMngUserTagDAO - .selectList(new QueryWrapper<ComMngUserTagDO>().eq("sys_flag", 1).or().eq("community_id", communityId)); + .selectList(null); if (!ObjectUtils.isEmpty(comMngUserTagDOS)) { - list = comMngUserTagDOS.stream().map(comMngUserTagDO -> comMngUserTagDO.getTagName()) - .collect(Collectors.toList()); + for (ComMngUserTagDO comMngUserTagDO : comMngUserTagDOS) { + if (!list.contains(comMngUserTagDO.getTagName())) { + list.add(comMngUserTagDO.getTagName()); + } + } +// list = comMngUserTagDOS.stream().map(comMngUserTagDO -> comMngUserTagDO.getTagName()) +// .collect(Collectors.toList()); } return R.ok(list); } -- Gitblit v1.7.1