From 686f53edd64c21516001942d0265a55fefd1be15 Mon Sep 17 00:00:00 2001
From: k94314517 <8417338+k94314517@user.noreply.gitee.com>
Date: 星期三, 31 七月 2024 19:23:33 +0800
Subject: [PATCH] 代码提交

---
 server/service/src/main/java/com/doumee/service/business/impl/UsersServiceImpl.java |   38 +++++++++++++++++++-------------------
 1 files changed, 19 insertions(+), 19 deletions(-)

diff --git a/server/service/src/main/java/com/doumee/service/business/impl/UsersServiceImpl.java b/server/service/src/main/java/com/doumee/service/business/impl/UsersServiceImpl.java
index e400da7..d4b54a2 100644
--- a/server/service/src/main/java/com/doumee/service/business/impl/UsersServiceImpl.java
+++ b/server/service/src/main/java/com/doumee/service/business/impl/UsersServiceImpl.java
@@ -176,7 +176,10 @@
                 .selectAll(Users.class);
         Utils.MP.blankToNull(pageWrap.getModel());
         if (StringUtils.isNotBlank(pageWrap.getModel().getPhone())) {
-            queryWrapper.apply(" t.id in ( select c.USER_ID from customer_user c where c.phone = '"+pageWrap.getModel().getPhone()+"'  ) ");
+            queryWrapper.apply(" t.id in ( select c.USER_ID from customer_user c where  c.isdeleted = 0 and  c.phone = '"+pageWrap.getModel().getPhone()+"'  ) ");
+        }
+        if (Objects.nonNull(pageWrap.getModel().getMemberId())) {
+            queryWrapper.apply(" t.id in ( select c.USER_ID from customer_user c where c.isdeleted = 0 and  c.member_id = '"+pageWrap.getModel().getMemberId()+"'  ) ");
         }
         if (pageWrap.getModel().getId() != null) {
             queryWrapper.eq(Users::getId, pageWrap.getModel().getId());
@@ -335,7 +338,7 @@
 
 
     @Override
-    public AccountResponse phoneLogin(String phone,String code){
+    public AccountResponse phoneLogin(String phone,String code,String openid){
         if(StringUtils.isEmpty(phone)||StringUtils.isEmpty(code)){
             throw new BusinessException(ResponseStatus.BAD_REQUEST);
         }
@@ -348,6 +351,12 @@
         }
         if(StringUtils.equals(users.getStatus(),Constants.ZERO+"")){
             throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"褰撳墠璐︽埛宸插仠鐢紝璇疯仈绯荤鐞嗗憳");
+        }
+        if(StringUtils.isNotBlank(openid)){
+            usersMapper.update(null,new UpdateWrapper<Users>().lambda().set(Users::getOpenid,null).eq(Users::getOpenid,openid).ne(Users::getId,users.getId()));
+            users.setOpenid(openid);
+            users.setEditDate(new Date());
+            usersMapper.updateById(users);
         }
         //楠岃瘉鐭俊
 //        SmsEmail model = smsEmailMapper.selectOne(new QueryWrapper<SmsEmail>().lambda()
@@ -394,6 +403,7 @@
             accountResponse.setSessionKey(session.getSessionKey());
             Users users = usersMapper.selectOne(new QueryWrapper<Users>().lambda().eq(Users::getOpenid,openId).last("limit 1"));
             if(Objects.isNull(users)){
+                accountResponse.setOpenid(openId);
                 accountResponse.setSessionKey(session.getSessionKey());
                 return accountResponse;
             }
@@ -449,22 +459,12 @@
 
 
     @Override
-    public void bindingOpenid(String code,Long userId){
-        try {
-            //鑾峰彇寰俊鏁忔劅鏁版嵁
-            WxMaJscode2SessionResult session = WxMiniConfig.wxPersonnelService.getUserService().getSessionInfo(code);
-            String openId = session.getOpenid();
-            if (com.baomidou.mybatisplus.core.toolkit.StringUtils.isBlank(openId)) {
-                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鑾峰彇openid澶辫触锛佽鑱旂郴绠$悊鍛�");
-            }
-            usersMapper.update(new UpdateWrapper<Users>().lambda().set(Users::getOpenid,null).eq(Users::getOpenid,openId));
-            Users users = usersMapper.selectById(userId);
-            users.setOpenid(openId);
-            users.setEditDate(new Date());
-            usersMapper.updateById(users);
-        } catch (WxErrorException e) {
-            e.printStackTrace();
-        }
+    public void bindingOpenid(String openid,Long userId){
+        usersMapper.update(new UpdateWrapper<Users>().lambda().set(Users::getOpenid,null).eq(Users::getOpenid,openid));
+        Users users = usersMapper.selectById(userId);
+        users.setOpenid(openid);
+        users.setEditDate(new Date());
+        usersMapper.updateById(users);
     }
 
     @Override
@@ -709,7 +709,7 @@
         //鍐呭鍒嗕韩娴锋姤鍥剧墖
         InputStream mpCode =  Constants.generateWxMiniImgStream(systemDictDataBiz.queryByCode(Constants.WX_MINI_CONFIG, Constants.WX_TOKEN_CUSTOMER).getCode(),
                 //"userId="+users.getId()+"&articleId="+param.getArticleId(),
-                 param.getArticleId()+"_"+users.getId(),
+                param.getArticleId()+"_"+users.getId(),
                 param.getPageUrl());//灏忕▼搴�
 
         InputStream inputStream = GeneratePicUtil.generateShareWithUserImg(

--
Gitblit v1.9.3