From eb49564ab17c6695d8928d5a63a57c58b3cfd79c Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期三, 11 十二月 2024 18:21:30 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java | 32 +++++++++++++++++++------------- 1 files changed, 19 insertions(+), 13 deletions(-) diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java index cb86390..24ceeb7 100644 --- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java +++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java @@ -153,6 +153,10 @@ }else{ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"瀵逛笉璧凤紝鍛樺伐淇℃伅鍚屾瀹夐槻骞冲彴澶辫触锛岃绋嶅悗閲嶈瘯锛�"); } + }catch (BusinessException e){ + //濡傛灉鍙戠敓寮傚父锛屽垹闄ゅ凡缁忓垱寤虹殑浜哄憳淇℃伅 + deleteHkUserBiz(new String[]{insert.getHkId()}); + throw e; }catch (Exception e){ //濡傛灉鍙戠敓寮傚父锛屽垹闄ゅ凡缁忓垱寤虹殑浜哄憳淇℃伅 e.printStackTrace(); @@ -243,7 +247,7 @@ * @return */ private boolean dealHkUserBiz(Member insert) { - String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() + String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_LOCAL_RESOURCE_PATH).getCode() +systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode(); UserAddRequest hkAddRequest = HkSyncOrgUserToHKServiceImpl.getUserAddModel(insert,path,Constants.ZERO); if(hkAddRequest == null){ @@ -266,7 +270,7 @@ return false; } private boolean dealHkUserForUpdateBiz(Member update ) { - String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() + String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_LOCAL_RESOURCE_PATH).getCode() +systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode(); UserAddRequest hkAddRequest = HkSyncOrgUserToHKServiceImpl.getUserAddModel(update,path,Constants.ONE); @@ -418,7 +422,6 @@ .ne(Member::getId,member.getId())) >0){ throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "韬唤璇佸彿銆�"+member.getIdcardNoNew()+"銆戝凡琚娇鐢紝涓嶈兘閲嶅"); } - member.setSex(Constants.getSexByCardNo( member.getIdcardNoNew()));//鏍规嵁韬唤璇佸彿鑾峰彇鎬у埆 member.setIdcardDecode( Constants.getTuominStr(member.getIdcardNoNew())); member.setIdcardNo(encrptNo); @@ -970,7 +973,7 @@ wrapper.lambda().ne(Member::getRemark,"浜鸿劯宸插悓姝ユ渶鏂�"); List<Member> list =memberMapper.selectList(wrapper); if(list!=null){ - String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() + String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_LOCAL_RESOURCE_PATH).getCode() +systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode(); for(Member m : list){ String faceId= HkSyncOrgUserToHKServiceImpl.dealMemberFace(m,path); @@ -1709,13 +1712,15 @@ String appSecret = systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_SECRET).getCode(); String getTokenUrl = WXConstant.GET_USER_INFO_URL.replace("CODE", code) .replace("APPID", appId).replace("SECRET", appSecret); -// JSONObject tokenJson = JSONObject.parseObject(HttpsUtil.get(getTokenUrl,true)); - String openId = code; -// if(!Objects.isNull(tokenJson.get("access_token"))){ -// openId = tokenJson.getString("openid"); -// } -// String openId = "12345"; + JSONObject tokenJson = JSONObject.parseObject(HttpsUtil.get(getTokenUrl,true)); + String openId = ""; + if(Objects.nonNull(tokenJson)&&!Objects.isNull(tokenJson.get("access_token"))){ + openId = tokenJson.getString("openid"); + } WxAuthorizeVO wxAuthorizeVO = new WxAuthorizeVO(); + if(StringUtils.isBlank(openId)){ + return wxAuthorizeVO; + } wxAuthorizeVO.setOpenid(openId); if(source==1){ //鏍规嵁openId 鏌ヨ鐢ㄦ埛淇℃伅 @@ -1763,7 +1768,7 @@ .last(" limit 1 ")); //闈炶瀹㈢敤鎴� 杩涜鍒ゆ柇鏄惁瀛樺湪鐢ㄦ埛 if(!Objects.isNull(user)){ - Member member = memberMapper.selectById(user.getId()); + Member member = memberMapper.selectById(user.getMemberId()); if(member.getIsdeleted() == Constants.ONE){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鐢ㄦ埛宸插垹闄�,璇疯仈绯荤鐞嗗憳"); } @@ -2092,6 +2097,7 @@ } if(memberMapper.selectCount(new QueryWrapper<Member>().lambda() .eq(Member::getIsdeleted,Constants.ZERO) + .ne(Member::getType,Constants.memberType.visitor) .eq(Member::getPhone,registerDriverDTO.getPhone()) )>Constants.ZERO){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鎵嬫満鍙峰凡娉ㄥ唽!"); @@ -2102,14 +2108,13 @@ )>Constants.ZERO){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鎵嬫満鍙峰凡娉ㄥ唽!"); }; - smsEmailService.validateCode(registerDriverDTO.getValidCode(),registerDriverDTO.getPhone()); String salt = RandomStringUtils.randomAlphabetic(6); ; Member member = new Member(); member.setCreateDate(new Date()); member.setIsdeleted(Constants.ZERO); - member.setType(Constants.THREE); + member.setType(Constants.memberType.driver); member.setName(registerDriverDTO.getName()); member.setPhone(registerDriverDTO.getPhone()); member.setStatus(Constants.ZERO); @@ -2127,6 +2132,7 @@ systemUser.setSalt(salt); systemUser.setPassword(member.getPassward()); systemUser.setStatus(Constants.ZERO); + systemUser.setType(Constants.memberType.driver); systemUser.setSource(Constants.TWO); systemUserMapper.insert(systemUser); -- Gitblit v1.9.3