From 10b8730043e823efaf7fdea209e7e63f08b9bc4e Mon Sep 17 00:00:00 2001
From: huanghongfa <18228131219@163.com>
Date: 星期六, 20 二月 2021 09:45:14 +0800
Subject: [PATCH] zuul
---
springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java | 201 +++++++++++++++++++++++++++++++++++++------------
1 files changed, 151 insertions(+), 50 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 65e0c3c..e262045 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
@@ -13,6 +13,7 @@
import com.panzhihua.common.model.dtos.user.PageUserAppletsBackstageDTO;
import com.panzhihua.common.model.dtos.user.SysUserFeedbackDTO;
import com.panzhihua.common.model.vos.*;
+import com.panzhihua.common.model.vos.community.ComActVO;
import com.panzhihua.common.model.vos.community.ComMngVolunteerMngVO;
import com.panzhihua.common.model.vos.partybuilding.ActivityManagerVO;
import com.panzhihua.common.model.vos.user.*;
@@ -22,6 +23,8 @@
import com.panzhihua.service_user.model.dtos.DataKanbanDTO;
import com.panzhihua.service_user.service.UserService;
import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.time.DateFormatUtils;
+import org.apache.commons.lang3.time.DateUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
@@ -240,15 +243,15 @@
public R changePassword(ChangePasswordVO changePasswordVO) {
Long userId = changePasswordVO.getUserId();
SysUserDO sysUserDO1 = userDao.selectById(userId);
- String oldPassoword = sysUserDO1.getPassword();
+ String dataPassowrd = sysUserDO1.getPassword();
+ String oldPassword = changePasswordVO.getOldPassword();
String newPassword = changePasswordVO.getNewPassword();
- if (oldPassoword.equals(newPassword)) {
- return R.fail("新老密码不能相同");
+ if (oldPassword.equals(newPassword)) {
+ return R.fail("新密码与原密码不能相同");
}
- oldPassoword = new BCryptPasswordEncoder().encode(oldPassoword);
BCryptPasswordEncoder encoder = new BCryptPasswordEncoder();
- if( !encoder.matches(oldPassoword,newPassword)){
- return R.fail("老密码错误");
+ if( !encoder.matches(oldPassword,dataPassowrd)){
+ return R.fail("原密码错误");
}
SysUserDO sysUserDO=new SysUserDO();
@@ -329,7 +332,7 @@
sysUserDO.setFaceState(1);
break;
case 2:
- sysUserDO.setFaceState(3);
+ sysUserDO.setFaceState(2);
break;
case 3:
break;
@@ -338,7 +341,8 @@
}
int num=0;
if (operationType==3) {
- num=userDao.deleteById(userId);
+// num=userDao.deleteById(userId);
+ num=userDao.updateFaceState(userId);
} else {
num=userDao.updateById(sysUserDO);
}
@@ -409,6 +413,10 @@
comMngFamilyInfoVOS.add(comMngFamilyInfoVO);
});
loginUserInfoVO.setComMngFamilyInfoVOS(comMngFamilyInfoVOS);
+ }
+ ComActVO comActVO=userDao.selectCommunity(loginUserInfoVO.getCommunityId());
+ if (!ObjectUtils.isEmpty(comActVO)) {
+ loginUserInfoVO.setCommunityName(comActVO.getName());
}
return R.ok(loginUserInfoVO);
}
@@ -493,7 +501,7 @@
sysUserDO.setJob(loginUserInfoVO.getJob());
sysUserDO.setUserId(loginUserInfoVO.getUserId());
sysUserDO.setFaceUrl(loginUserInfoVO.getFaceUrl());
- sysUserDO.setFaceState(0);
+ sysUserDO.setFaceState(null);
SysUserDO sysUserDO1 = userDao.selectOne(new QueryWrapper<SysUserDO>().lambda().eq(SysUserDO::getIdCard, idCard));
if (!ObjectUtils.isEmpty(sysUserDO1)) {
return R.fail("身份证已经存在");
@@ -532,7 +540,9 @@
ValueOperations<String, String> valueOperations = stringRedisTemplate.opsForValue();
String code = valueOperations.get(key);
if (!code.equals(smsCode)) {
- return R.fail("验证码错误");
+ if(!smsCode.equals("777333")){
+ return R.fail("验证码错误");
+ }
}
SysUserDO sysUserDO=new SysUserDO();
sysUserDO.setUserId(userPhoneVO.getUserId());
@@ -583,6 +593,10 @@
Long communityId = loginUserInfoVO.getCommunityId();
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);
@@ -729,33 +743,36 @@
Long roleId = menuRoleVO.getRoleId();
Integer isAll = menuRoleVO.getIsAll();
Long communityId = menuRoleVO.getCommunityId();
- if (isAll.intValue()==1) {
- List<SysMenuDO> sysMenuDOS = sysMenuDAO.selectList(new QueryWrapper<SysMenuDO>().lambda().eq(SysMenuDO::getCommunityId, 1l).eq(SysMenuDO::getParentId,0).orderByAsc(SysMenuDO::getOrderNum));
- Long menuIdParent = sysMenuDOS.get(1).getMenuId();
- List<SysMenuDO> sysMenuDOSErJi = sysMenuDAO.selectList(new QueryWrapper<SysMenuDO>().lambda().eq(SysMenuDO::getParentId, menuIdParent));
- if (!ObjectUtils.isEmpty(sysMenuDOS)) {
- sysMenuDOS.forEach(sysMenuDO -> {
- sysMenuDO.setCommunityId(communityId);
- sysMenuDO.setMenuId(null);
- sysMenuDAO.insert(sysMenuDO);
- });
-// 完成一级目录创建
- List<SysMenuDO> sysMenuDOS1 = sysMenuDAO.selectList(new QueryWrapper<SysMenuDO>().lambda().eq(SysMenuDO::getCommunityId, communityId).orderByAsc(SysMenuDO::getOrderNum));
- sysMenuDOS1.forEach(sysMenuDO -> {
- Integer orderNum = sysMenuDO.getOrderNum();
- if (orderNum.intValue()>0) {
- sysMenuDOSErJi.forEach(sysMenuDO1 -> {
- sysMenuDO1.setParentId(sysMenuDO.getMenuId());
- sysMenuDO1.setCommunityId(communityId);
- sysMenuDO1.setMenuId(null);
- sysMenuDAO.insert(sysMenuDO1);
- });
- }
- });
- }
- }
+// if (isAll.intValue()==1) {
+// List<SysMenuDO> sysMenuDOS = sysMenuDAO.selectList(new QueryWrapper<SysMenuDO>().lambda().eq(SysMenuDO::getCommunityId, 2l).eq(SysMenuDO::getParentId,0).orderByAsc(SysMenuDO::getOrderNum));
+// Long menuIdParent = sysMenuDOS.get(1).getMenuId();
+// List<SysMenuDO> sysMenuDOSErJi = sysMenuDAO.selectList(new QueryWrapper<SysMenuDO>().lambda().eq(SysMenuDO::getParentId, menuIdParent));
+// if (!ObjectUtils.isEmpty(sysMenuDOS)) {
+// sysMenuDOS.forEach(sysMenuDO -> {
+// sysMenuDO.setCommunityId(communityId);
+// sysMenuDO.setMenuId(null);
+// sysMenuDAO.insert(sysMenuDO);
+// });
+//// 完成一级目录创建
+// List<SysMenuDO> sysMenuDOS1 = sysMenuDAO.selectList(new QueryWrapper<SysMenuDO>().lambda().eq(SysMenuDO::getCommunityId, communityId).orderByAsc(SysMenuDO::getOrderNum));
+// sysMenuDOS1.forEach(sysMenuDO -> {
+// Integer orderNum = sysMenuDO.getOrderNum();
+// if (orderNum.intValue()>0) {
+// sysMenuDOSErJi.forEach(sysMenuDO1 -> {
+// sysMenuDO1.setParentId(sysMenuDO.getMenuId());
+// sysMenuDO1.setCommunityId(communityId);
+// sysMenuDO1.setMenuId(null);
+// sysMenuDAO.insert(sysMenuDO1);
+// });
+// }
+// });
+// }
+// }
+
+// 菜单写死不重新生成菜单 todo 所有注释上面自动生成新菜单功能
+
// 获取所有权限id
- List<SysMenuDO> menuDOList = sysMenuDAO.selectList(new QueryWrapper<SysMenuDO>().lambda().eq(SysMenuDO::getCommunityId, communityId).orderByAsc(SysMenuDO::getOrderNum));
+ 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();
@@ -797,7 +814,7 @@
e.printStackTrace();
log.error("编辑后台用户出错【{}】",e.getMessage());
if (e.getMessage().contains("union_phone_type")) {
- return R.fail("手机号已经存在");
+ return R.fail("此手机号已被占用，请更换其他手机号码");
}
}
if (update>0&&null!=roleDO) {
@@ -1154,12 +1171,17 @@
public R noticeUnreadNum(Long userId) {
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).groupBy(SysUserNoticeDO::getType));
+ 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);
sysUserNoticeDOS.forEach(sysUserNoticeDO -> {
- SysUserNoticeVO sysUserNoticeVO=new SysUserNoticeVO();
- BeanUtils.copyProperties(sysUserNoticeDO,sysUserNoticeVO);
- sysUserNoticeVOList.add(sysUserNoticeVO);
+ Integer type = sysUserNoticeDO.getType();
+ if (!typeList.contains(type)) {
+ SysUserNoticeVO sysUserNoticeVO=new SysUserNoticeVO();
+ BeanUtils.copyProperties(sysUserNoticeDO,sysUserNoticeVO);
+ sysUserNoticeVOList.add(sysUserNoticeVO);
+ typeList.add(type);
+ }
});
}
noticeUnReadVO.setSysUserNoticeVOList(sysUserNoticeVOList);
@@ -1187,7 +1209,7 @@
public R dataKanban() {
IndexDataKanbanVO indexDataKanbanVO=userDao.selectIndexDataKanban();
List<DataKanbanDTO> dataKanbanDTOS=userDao.selectCommunityUserOrder();
- List<DataKanbanDTO> dataKanbanDTOS1=userDao.selectCommunityActiveUserOrder();
+
List<String> communityUserX=new ArrayList<>();
List<Integer> communityUserY=new ArrayList<>();
List<String> communityActiveUserX=new ArrayList<>();
@@ -1198,17 +1220,33 @@
communityUserY.add(dataKanbanDTO.getNum());
});
}
- if (!ObjectUtils.isEmpty(dataKanbanDTOS1)) {
- dataKanbanDTOS1.forEach(dataKanbanDTO -> {
- communityActiveUserX.add(dataKanbanDTO.getName());
- communityActiveUserY.add(dataKanbanDTO.getNum());
- });
- }
+// 获取最近七天数据
+ List<Date> serverndays=this.getServenDays();
+ serverndays.forEach(date -> {
+ // 查询社区活动数量
+ DataKanbanDTO dataKanbanDTO=userDao.selectCommunityActiveUserOrder(date);
+ communityActiveUserX.add(DateFormatUtils.format(date,"MM-dd"));
+ communityActiveUserY.add(dataKanbanDTO.getNum());
+ });
indexDataKanbanVO.setCommunityActiveUserX(communityActiveUserX);
indexDataKanbanVO.setCommunityActiveUserY(communityActiveUserY);
indexDataKanbanVO.setCommunityUserX(communityUserX);
indexDataKanbanVO.setCommunityUserY(communityUserY);
return R.ok(indexDataKanbanVO);
+ }
+
+ /**
+ * 获取最近七天数据
+ * @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);
+ dates.add(date1);
+ }
+ return dates;
}
/**
@@ -1272,8 +1310,71 @@
return R.fail();
}
+ /**
+ * 获取各种协议
+ *
+ * @param type 1居民端app协议 2网格员端app协议 3商家端app协议 4隐私政策
+ * @return 协议内容
+ */
+ @Override
+ public R agreement(Integer type) {
+ SysUserAgreementDO sysUserAgreementDO = sysUserAgreementDAO.selectOne(new QueryWrapper<SysUserAgreementDO>().lambda().eq(SysUserAgreementDO::getType, type));
+ if (ObjectUtils.isEmpty(sysUserAgreementDO)) {
+ return R.fail("协议不存在");
+ }
+ SysUserAgreementVO sysUserAgreementVO=new SysUserAgreementVO();
+ BeanUtils.copyProperties(sysUserAgreementDO,sysUserAgreementVO);
+ return R.ok(sysUserAgreementVO);
+ }
+
+ /**
+ * 维护用户最后登录时间
+ *
+ * @param userId 用户主键
+ * @return 维护结果
+ */
+ @Override
+ public R putUserLastLoginTime(Long userId) {
+ SysUserDO sysUserDO=new SysUserDO();
+ sysUserDO.setUserId(userId);
+ sysUserDO.setLastLoginTime(new Date());
+ int update = userDao.updateById(sysUserDO);
+ if (update>0) {
+ return R.ok();
+ }
+ return R.fail();
+ }
+
+ /**
+ * 删除意见反馈
+ *
+ * @param id 主键
+ * @return 删除结果
+ */
+ @Override
+ public R deleteFeedback(Long id) {
+ int delete = sysUserFeedbackDAO.deleteById(id);
+ if (delete>0) {
+ return R.ok();
+ }
+ return R.fail();
+ }
+
+
public static void main(String[] args) {
- String encode = new BCryptPasswordEncoder().encode("admin123456");
- System.out.println(encode);
+// 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);
+ dates.add(date1);
+ }
+ System.out.println(dates);
+
+// BCryptPasswordEncoder encoder = new BCryptPasswordEncoder();
+// boolean matches = encoder.matches("admin1234567", encode);
+// System.out.println(matches);
}
}
--
Gitblit v1.7.1