From 7915bccb915fad88e885d54832b120cf2d36a036 Mon Sep 17 00:00:00 2001 From: k94314517 <8417338+k94314517@user.noreply.gitee.com> Date: 星期三, 17 七月 2024 18:26:56 +0800 Subject: [PATCH] 代码提交 --- server/service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java | 63 +++++++++++++++---------------- 1 files changed, 31 insertions(+), 32 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 deea2cc..4d3cbf2 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,14 +277,14 @@ @Override public AccountResponse wxLogin(String code){ -// try { - //鑾峰彇寰俊鏁忔劅鏁版嵁 -// WxMaJscode2SessionResult session = WxMiniConfig.wxCustomerService.getUserService().getSessionInfo(code); -// String openId = session.getOpenid(); -// if (com.baomidou.mybatisplus.core.toolkit.StringUtils.isBlank(openId)) { -// throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鑾峰彇openid澶辫触锛佽鑱旂郴绠$悊鍛�"); -// } - String openId = code; + try { +// 鑾峰彇寰俊鏁忔劅鏁版嵁 + WxMaJscode2SessionResult session = WxMiniConfig.wxCustomerService.getUserService().getSessionInfo(code); + String openId = session.getOpenid(); + if (com.baomidou.mybatisplus.core.toolkit.StringUtils.isBlank(openId)) { + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鑾峰彇openid澶辫触锛佽鑱旂郴绠$悊鍛�"); + } +// String openId = code; Member member = memberMapper.selectOne(new QueryWrapper<Member>().eq("OPENID", openId)); if (member == null) { member = new Member(); @@ -316,13 +316,13 @@ String token = JwtTokenUtil.generateToken(payLoad); AccountResponse accountResponse = new AccountResponse(); accountResponse.setToken(token); -// accountResponse.setSessionKey(session.getSessionKey()); + accountResponse.setSessionKey(session.getSessionKey()); accountResponse.setMember(member); return accountResponse; -// } catch (WxErrorException e) { -// e.printStackTrace(); -// } -// throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"寰俊鐧诲綍寮傚父锛佽鑱旂郴绠$悊鍛�"); + } catch (WxErrorException e) { + e.printStackTrace(); + } + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"寰俊鐧诲綍寮傚父锛佽鑱旂郴绠$悊鍛�"); } @Override @@ -454,14 +454,15 @@ param.setOpenId(member.getOpenid()); ZTUserGetTokenResponse ztUserGetTokenResponse = zbomZhongTaiService.getUserToken(param); if(Objects.nonNull(ztUserGetTokenResponse)){ + Date date =new Date(System.currentTimeMillis()+(Constants.formatLongNum(ztUserGetTokenResponse.getExpire())<=0?2*60*60*1000:ztUserGetTokenResponse.getExpire()*1000)); member.setToken(ztUserGetTokenResponse.getToken()); - //TODO 鏆傛棤杩囨湡鏃ユ湡 - memberMapper.update(new UpdateWrapper<Member>().lambda().set(Member::getToken,ztUserGetTokenResponse.getToken()) + memberMapper.update(new UpdateWrapper<Member>().lambda() + .set(Member::getToken,ztUserGetTokenResponse.getToken()) + .set(Member::getTokenDate,date)//榛樿鏈夋晥鏈熶负涓ゅ皬鏃� .eq(Member::getId,member.getId())); ztBaseInfoResponse.setToken(ztUserGetTokenResponse.getToken()); - return ztBaseInfoResponse; }else{ - throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"涓彴TOKEN鑾峰彇澶辫触锛岃鑱旂郴绠$悊鍛�"); +// throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"涓彴TOKEN鑾峰彇澶辫触锛岃鑱旂郴绠$悊鍛�"); } } ztBaseInfoResponse.setToken(member.getToken()); @@ -482,27 +483,29 @@ ZTUserGetTokenResponse ztUserGetTokenResponse = zbomZhongTaiService.getUserToken(param); if(Objects.nonNull(ztUserGetTokenResponse)){ users.setToken(ztUserGetTokenResponse.getToken()); - //TODO 鏆傛棤杩囨湡鏃ユ湡 + Date date =new Date(System.currentTimeMillis()+(Constants.formatLongNum(ztUserGetTokenResponse.getExpire())<=0?2*60*60*1000:ztUserGetTokenResponse.getExpire()*1000)); usersMapper.update(new UpdateWrapper<Users>().lambda().set(Users::getToken,ztUserGetTokenResponse.getToken()) + .set(Users::getTokenDate,date)//榛樿鏈夋晥鏈熶负涓ゅ皬鏃� .eq(Users::getId,users.getId())); ztBaseInfoResponse.setToken(ztUserGetTokenResponse.getToken()); return ztBaseInfoResponse; }else{ - throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"涓彴TOKEN鑾峰彇澶辫触锛岃鑱旂郴绠$悊鍛�"); +// throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"涓彴TOKEN鑾峰彇澶辫触锛岃鑱旂郴绠$悊鍛�"); } } ztBaseInfoResponse.setToken(users.getToken()); - return ztBaseInfoResponse; +// return ztBaseInfoResponse; }else{ - throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鍙傛暟閿欒"); +// throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鍙傛暟閿欒"); } + return ztBaseInfoResponse; } @Override - public void logOff(Long memberId){ + public ZTBaseRequst logOff(Long memberId){ Member member = memberMapper.selectById(memberId); if(Objects.isNull(member)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); @@ -517,16 +520,12 @@ ztBaseRequst.setUserType(Constants.CUSTOMER); ztBaseRequst.setOpenId(member.getOpenid()); ztBaseRequst.setToken(member.getToken()); - Boolean logoutFlag = zbomZhongTaiService.userLogout(ztBaseRequst); - if(logoutFlag){ - memberMapper.update(new UpdateWrapper<Member>().lambda() - .set(Member::getPhone,null) - .set(Member::getEditDate,new Date()) - .eq(Member::getId,member.getId()) - ); - return; - } - throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"涓彴娉ㄩ攢澶辫触锛岃鑱旂郴绠$悊鍛�"); + memberMapper.update(new UpdateWrapper<Member>().lambda() + .set(Member::getPhone,null) + .set(Member::getEditDate,new Date()) + .eq(Member::getId,member.getId()) + ); + return ztBaseRequst; } -- Gitblit v1.9.3