From cdca957e4835e359a89fe4c7c9833ab0c78ee4e3 Mon Sep 17 00:00:00 2001 From: lidongdong <1459917685@qq.com> Date: 星期一, 01 四月 2024 11:18:10 +0800 Subject: [PATCH] 修改西区uu洗车登录接口500 7 --- springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java | 170 +++++++++++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 143 insertions(+), 27 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 eda1ddf..eb305e4 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 @@ -343,6 +343,7 @@ if (nonNull(sysUserDO.getStreetId())){ loginUserInfoVO.setStreetId(sysUserDO.getStreetId()); } + loginUserInfoVO.setLoveIntegral(sysUserDO.getLoveIntegral()); loginUserInfoVO.setUserId(sysUserDO.getUserId()); loginUserInfoVO.setName(sysUserDO.getName()); loginUserInfoVO.setPassword(sysUserDO.getPassword()); @@ -405,6 +406,7 @@ } LoginUserInfoVO loginUserInfoVO = new LoginUserInfoVO(); BeanUtils.copyProperties(sysUserDO, loginUserInfoVO); + loginUserInfoVO.setLoveIntegral(sysUserDO.getLoveIntegral()); List<SysRoleDO> roleDOList = roleDAO.selectByUserId(sysUserDO.getUserId()); Set<String> set = new HashSet<>(); if (!ObjectUtils.isEmpty(roleDOList)) { @@ -800,12 +802,14 @@ * @return 人员详情 */ @Override - public R<LoginUserInfoVO> detailUser(Long userId) { + public R<LoginUserInfoVO> detailUser(Long userId) + { LoginUserInfoVO loginUserInfoVO = new LoginUserInfoVO(); SysUserDO sysUserDO = userDao.selectById(userId); if (ObjectUtils.isEmpty(sysUserDO)) { return R.fail("人员不存在"); } + BeanUtils.copyProperties(sysUserDO, loginUserInfoVO); List<ComMngFamilyInfoDO> comMngFamilyInfoDOS = comMngFamilyInfoDAO .selectList(new QueryWrapper<ComMngFamilyInfoDO>().lambda().eq(ComMngFamilyInfoDO::getUserId, userId)); @@ -885,6 +889,20 @@ } if (sysUserDO.getBindingCheckUnitId() != null) { loginUserInfoVO.setBackstageType(4); + } + //判断是否是商家账号 + Long storeId = userDao.selectStoreIdIdByUserId(sysUserDO.getUserId()); + if (null != storeId){ + loginUserInfoVO.setBackstageUserId(sysUserDO.getUserId()); + loginUserInfoVO.setBackstageType(5); + loginUserInfoVO.setStoreIdId(storeId); + } + + SysUserRoleDO sysUserRoleDO=sysUserRoleDAO.selectOne(new QueryWrapper<SysUserRoleDO>() + .lambda().eq(SysUserRoleDO::getUserId,sysUserDO.getUserId())); + if(sysUserRoleDO!=null && sysUserRoleDO.getRoleId()!=null ) + { + loginUserInfoVO.setRoleId(sysUserRoleDO.getRoleId()+""); } return R.ok(loginUserInfoVO); } @@ -1244,6 +1262,15 @@ @Override @Transactional(rollbackFor = Exception.class) public R addUserBackstage(AdministratorsUserVO administratorsUserVO) { + + List<SysUserDO> list=userDao.selectList(new QueryWrapper<SysUserDO>().lambda(). + eq(SysUserDO::getAppId,administratorsUserVO.getAppid()). + eq(SysUserDO::getAccount,administratorsUserVO.getAccount())); + if(list!=null && list.size()>0) + { + return R.fail("账户已存在!"); + } + ComActVO comActVO = userDao.selectCommunity(administratorsUserVO.getCommunityId()); if (nonNull(comActVO)) { List<ComAreaTownCommunityVO> areaTownList = userDao.selectAreaTownCommunity(comActVO.getName()); @@ -1276,11 +1303,29 @@ } sysRoleDO.setRoleSort(0); sysRoleDO.setCreateBy(administratorsUserVO.getUserId()); - int insert = roleDAO.insert(sysRoleDO); - if (insert > 0) { - SysRoleDO sysRoleDO1 = roleDAO.selectOne( - new QueryWrapper<SysRoleDO>().lambda().eq(SysRoleDO::getRoleKey, sysRoleDO.getRoleKey())); - roleId = sysRoleDO1.getRoleId(); + sysRoleDO.setRoleId(Snowflake.getId()); + + SysRoleDO sysRoleDOSelext = roleDAO.selectOne( + new QueryWrapper<SysRoleDO>().lambda().eq(SysRoleDO::getRoleKey, sysRoleDO.getRoleKey())); + + if(sysRoleDOSelext==null) + { + int insert = roleDAO.insert(sysRoleDO); + if (insert > 0) { + SysRoleDO sysRoleDO1 = roleDAO.selectOne( + new QueryWrapper<SysRoleDO>().lambda().eq(SysRoleDO::getRoleId, sysRoleDO.getRoleId())); + roleId = sysRoleDO1.getRoleId(); + // 新角色设置所有权限 + MenuRoleVO menuRoleVO = new MenuRoleVO(); + menuRoleVO.setIsAll(1); + menuRoleVO.setCommunityId(communityId); + menuRoleVO.setRoleId(roleId); + this.putMenuRole(menuRoleVO); + } + } + else + { + roleId = sysRoleDOSelext.getRoleId(); // 新角色设置所有权限 MenuRoleVO menuRoleVO = new MenuRoleVO(); menuRoleVO.setIsAll(1); @@ -1288,6 +1333,7 @@ menuRoleVO.setRoleId(roleId); this.putMenuRole(menuRoleVO); } + } if (roleId.intValue() == 777777777) { SysRoleDO sysRoleDO = new SysRoleDO(); @@ -1295,11 +1341,47 @@ sysRoleDO.setRoleKey(Constants.STREET_ROLE_KEY + administratorsUserVO.getStreetId()); sysRoleDO.setRoleSort(0); sysRoleDO.setCreateBy(administratorsUserVO.getUserId()); - int insert = roleDAO.insert(sysRoleDO); - if (insert > 0) { - SysRoleDO sysRoleDO1 = roleDAO.selectOne( - new QueryWrapper<SysRoleDO>().lambda().eq(SysRoleDO::getRoleKey, sysRoleDO.getRoleKey())); - roleId = sysRoleDO1.getRoleId(); + sysRoleDO.setRoleId(Snowflake.getId()); + + SysRoleDO sysRoleDOSelext = roleDAO.selectOne( + new QueryWrapper<SysRoleDO>().lambda().eq(SysRoleDO::getRoleKey, sysRoleDO.getRoleKey())); + + if(sysRoleDOSelext==null) + { + int insert = roleDAO.insert(sysRoleDO); + if (insert > 0) { + SysRoleDO sysRoleDO1 = roleDAO.selectOne( + new QueryWrapper<SysRoleDO>().lambda().eq(SysRoleDO::getRoleId, sysRoleDO.getRoleId())); + roleId = sysRoleDO1.getRoleId(); + // 新街道管理员角色设置固定三社权限 + MenuRoleVO menuRoleVO = new MenuRoleVO(); + List<Long> menu = new ArrayList<>(); + if (administratorsUserVO.getSocialType() == 1) { + menu.add(233L); + menu.add(234L); + menu.add(235L); + menu.add(236L); + menu.add(237L); + } else if (administratorsUserVO.getSocialType() == 2) { + menu.add(233L); + menu.add(234L); + menu.add(236L); + menu.add(237L); + menu.add(238L); + } else if (administratorsUserVO.getSocialType() == 3) { + menu.add(233L); + menu.add(237L); + } else { + menuRoleVO.setIsAll(1); + } + menuRoleVO.setMenuIds(menu); + menuRoleVO.setRoleId(roleId); + this.putMenuRole(menuRoleVO); + } + } + else + { + roleId = sysRoleDOSelext.getRoleId(); // 新街道管理员角色设置固定三社权限 MenuRoleVO menuRoleVO = new MenuRoleVO(); List<Long> menu = new ArrayList<>(); @@ -1325,6 +1407,7 @@ menuRoleVO.setRoleId(roleId); this.putMenuRole(menuRoleVO); } + } SysRoleDO roleDO = roleDAO.selectById(roleId); if (ObjectUtils.isEmpty(roleDO)) { @@ -1393,10 +1476,10 @@ } sysRoleDO.setRoleSort(0); sysRoleDO.setCreateBy(administratorsUserVO.getUserId()); - SysRoleDO sysRoleDO1 = roleDAO.selectOne( + List<SysRoleDO> sysRoleDO1 = roleDAO.selectList( new QueryWrapper<SysRoleDO>().lambda().eq(SysRoleDO::getRoleKey, sysRoleDO.getRoleKey())); - if (sysRoleDO1 != null) { - sysRoleDO = sysRoleDO1; + if (sysRoleDO1 != null && sysRoleDO1.size()>0 ) { + sysRoleDO = sysRoleDO1.get(0); roleId = sysRoleDO.getRoleId(); } else { roleDAO.insert(sysRoleDO); @@ -3406,14 +3489,47 @@ } catch (Exception e) { e.printStackTrace(); } - Map<String, String> headerMap = new HashMap<>(); + Map<String, Object> headerMap = new HashMap<>(); headerMap.put("appid", appId); - String resultJson = HttpClientUtil.get("https://api.uucsh.cn/member/wx/get-access?province=" + uuLoginVO.getProvince() + "&city=" + uuLoginVO.getCity() + "&area=" + uuLoginVO.getArea() + "&appid=" + appId + "×tamp=" + uuLoginVO.getTimestamp() + "&sign=" + uuLoginVO.getSign() + "&mobile=" + uuLoginVO.getMobile() + "&couponId=" + uuLoginVO.getCouponId(), headerMap, null); - JSONObject result = JSON.parseObject(resultJson); - if (result.get("status").equals(1)) { - return R.ok(result.get("data")); + + String str="https://uu-api.imashuo.com/member/wx/get-access?"+ "appid=" + appId + + "×tamp=" + uuLoginVO.getTimestamp() + + "&sign=" + uuLoginVO.getSign() + + "&mobile=" + uuLoginVO.getMobile(); + + if(!StringUtils.isEmpty(uuLoginVO.getProvince())) + { + str=str+"&province=" + uuLoginVO.getProvince(); } - return R.fail("信息错误"); + + + if(!StringUtils.isEmpty(uuLoginVO.getCity())) + { + str=str+"&city=" + uuLoginVO.getCity(); + } + + if(!StringUtils.isEmpty(uuLoginVO.getArea())) + { + str=str+"&area=" + uuLoginVO.getArea(); + } + + if(!StringUtils.isEmpty(uuLoginVO.getCouponId())) + { + str=str+"&couponId=" + uuLoginVO.getCouponId(); + } + +// String resultJson = HttpClientUtil.get("https://uu-api.imashuo.com/member/wx/get-acces.s?province=" + uuLoginVO.getProvince() + "&city=" + uuLoginVO.getCity() + "&area=" + uuLoginVO.getArea() + "&appid=" + appId + "×tamp=" + uuLoginVO.getTimestamp() + "&sign=" + uuLoginVO.getSign() + "&mobile=" + uuLoginVO.getMobile() + "&couponId=" + uuLoginVO.getCouponId(), headerMap, null); + String resultJson = null; + try { + resultJson = HttpClientUtil.httpGet(str ,headerMap,10000 ,null); + } catch (Exception e) { + e.printStackTrace(); + } + JSONObject result = JSON.parseObject(resultJson); +// if (result.get("status").equals(1)) { +// return R.ok(result.get("data")+" "+resultJson); +// } + return R.fail("信息错误"+" "+resultJson); } @Override @@ -3768,16 +3884,16 @@ @Override public R getAllCommunityList() { List<Integer> areaList = areaCodeList(); - List<AreaVOS> areaVOList = new ArrayList<>(); + List<AreaVOStr> areaVOList = new ArrayList<>(); for (Integer code : areaList) { - AreaVOS areaVO = new AreaVOS(); - areaVO.setId(code); + AreaVOStr areaVO = new AreaVOStr(); + areaVO.setId(code+""); areaVO.setName(areaCodeToName(code.longValue())); - List<StreetVOS> streetVOS = userDao.selectStreetByAreaCode(code); - Iterator<StreetVOS> iterator = streetVOS.listIterator(); + List<StreetVOStr> streetVOS = userDao.selectStreetByAreaCodeStr(code); + Iterator<StreetVOStr> iterator = streetVOS.listIterator(); while (iterator.hasNext()) { - StreetVOS vo = iterator.next(); - List<CommunityVO> communityVOS = userDao.selectCommunityByStreetId(vo.getId(), 3); + StreetVOStr vo = iterator.next(); + List<CommunityVO> communityVOS = userDao.selectCommunityByStreetId(Long.parseLong(vo.getId()), 3); vo.setChildList(communityVOS); } -- Gitblit v1.7.1