From 5a42219c9f91fd8fa77ddd8c8945d03168250b68 Mon Sep 17 00:00:00 2001 From: k94314517 <8417338+k94314517@user.noreply.gitee.com> Date: 星期一, 29 七月 2024 19:26:09 +0800 Subject: [PATCH] 代码提交 --- server/service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java | 48 +++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 39 insertions(+), 9 deletions(-) diff --git a/server/service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java b/server/service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java index 0d0b8a6..494e1bf 100644 --- a/server/service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java +++ b/server/service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java @@ -277,8 +277,8 @@ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鑾峰彇openid澶辫触锛佽鑱旂郴绠$悊鍛�"); } // String openId = code; - Member member = memberMapper.selectOne(new QueryWrapper<Member>().eq("OPENID", openId).isNotNull("phone")); - Users users = new Users(); + Member member = memberMapper.selectOne(new QueryWrapper<Member>().eq("OPENID", openId).last(" limit 1 ")); + Users users = null; if(StringUtils.isNotBlank(userId)){ users = usersMapper.selectById(userId); } @@ -320,6 +320,41 @@ e.printStackTrace(); } throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"寰俊鐧诲綍寮傚父锛佽鑱旂郴绠$悊鍛�"); + } + + + @Override + public AccountResponse testLogin(String openid){ + String openId = openid; + Member member = memberMapper.selectOne(new QueryWrapper<Member>().eq("OPENID", openId).isNotNull("phone")); + + if (member == null) { + member = new Member(); + member.setNickname("寰俊鐢ㄦ埛"+ CodeVerifyUtils.createVerificationCode(4)); + member.setCreateDate(new Date()); + member.setIsdeleted(Constants.ZERO); + member.setOpenid(openId); + member.setType(Constants.ZERO); + //濡傛灉缁戝畾浜嗗璐� 鍒欑洿鎺ヤ娇鐢ㄥ凡缁戝畾瀵艰喘淇℃伅 璺宠繃鎵嬫満鍙风粦瀹氱殑鐘舵�� + member.setAuthStatus(Constants.ZERO); + ZTUserGetTokenResponse ztUserGetTokenResponse = this.syncZhongTaiUser(member); + if(!Objects.isNull(ztUserGetTokenResponse)){ + member.setToken(ztUserGetTokenResponse.getToken()); + } + memberMapper.insert(member); + }else{ + ZTUserGetTokenResponse ztUserGetTokenResponse = this.syncZhongTaiUser(member); + if(!Objects.isNull(ztUserGetTokenResponse)){ + member.setToken(ztUserGetTokenResponse.getToken()); + memberMapper.updateById(member); + } + member = this.getMemberInfo(member.getId()); + } + String token = JwtTokenUtil.generateTokenForZb(member.getId(),ZTConstants.CUSTOMER, JSONObject.toJSON(member).toString(),redisTemplate); + AccountResponse accountResponse = new AccountResponse(); + accountResponse.setToken(token); + accountResponse.setMember(member); + return accountResponse; } public static void saveCustomerUser(ZbomZhongTaiService zbomZhongTaiService,CustomerUserMapper customerUserMapper,Users users,Long memberId,String openId){ @@ -383,12 +418,6 @@ Member memberDto = new Member(); BeanUtils.copyProperties(editMemberRequest,memberDto); memberDto.setOpenid(member.getOpenid()); -// ZTUserGetTokenResponse ztUserGetTokenResponse = this.syncZhongTaiUser(memberDto); -// if(Objects.isNull(ztUserGetTokenResponse)){ -// throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"涓彴鏈嶅姟璋冭捣澶辫触!"); -// }else{ -// member.setToken(ztUserGetTokenResponse.getToken()); -// } memberMapper.updateById(memberDto); return this.getMemberInfo(member.getId()); } @@ -455,7 +484,8 @@ String prefix = systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE, Constants.RESOURCE_PATH).getCode() + systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE, Constants.MEMBER).getCode(); member.setPrefix(prefix); - if( customerUserMapper.selectCount(new QueryWrapper<CustomerUser>().lambda().eq(CustomerUser::getIsdeleted,Constants.ZERO).eq(CustomerUser::getMemberId,member.getId()))>0){ + if( customerUserMapper.selectCount(new QueryWrapper<CustomerUser>() + .lambda().eq(CustomerUser::getIsdeleted,Constants.ZERO).eq(CustomerUser::getMemberId,member.getId()))>0){ member.setAuthStatus(Constants.TWO); }else{ if(StringUtils.isBlank(member.getPhone())){ -- Gitblit v1.9.3