From b2d360d9113b6955287108ca9e90d76a1f3c1419 Mon Sep 17 00:00:00 2001
From: liukangdong <898885815@qq.com>
Date: 星期日, 29 九月 2024 15:05:11 +0800
Subject: [PATCH] Merge branch 'master' of http://139.186.142.91:10010/r/productDev/zbomyoujia

---
 server/service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java |   69 +++++++++++++++++++++++-----------
 1 files changed, 47 insertions(+), 22 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 a7bc725..9c643d6 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
@@ -290,12 +290,9 @@
                 member.setIsdeleted(Constants.ZERO);
                 member.setOpenid(openId);
                 member.setType(Constants.ZERO);
+                member.setAuthStatus(Constants.ZERO);
+                member.setStatus(Constants.ZERO);
                 //濡傛灉缁戝畾浜嗗璐� 鍒欑洿鎺ヤ娇鐢ㄥ凡缁戝畾瀵艰喘淇℃伅 璺宠繃鎵嬫満鍙风粦瀹氱殑鐘舵��
-//                if(Objects.nonNull(users)){
-//                    member.setAuthStatus(Constants.TWO);
-//                }else{
-//                    member.setAuthStatus(Constants.ZERO);
-//                }
                 ZTUserGetTokenResponse ztUserGetTokenResponse = this.syncZhongTaiUser(member);
                 if(!Objects.isNull(ztUserGetTokenResponse)){
                     member.setToken(ztUserGetTokenResponse.getToken());
@@ -304,12 +301,14 @@
                 }
                 memberMapper.insert(member);
             }else{
-                ZTUserGetTokenResponse ztUserGetTokenResponse = this.syncZhongTaiUser(member);
-                if(!Objects.isNull(ztUserGetTokenResponse)){
-                    member.setToken(ztUserGetTokenResponse.getToken());
-                    member.setZtUserId(StringUtils.defaultString(ztUserGetTokenResponse.getZtUserId(),ztUserGetTokenResponse.getToken()));
+                ZTBaseInfoResponse ztBaseInfoResponse = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,
+                        member.getId(),ZTConstants.CUSTOMER);
+                if(!Objects.isNull(ztBaseInfoResponse)){
+                    member.setToken(ztBaseInfoResponse.getToken());
+                    member.setZtUserId(StringUtils.defaultString(ztBaseInfoResponse.getZtUserId(),ztBaseInfoResponse.getToken()));
                     Member update = new Member();
-                    update.setZtUserId(StringUtils.defaultString(ztUserGetTokenResponse.getZtUserId(),ztUserGetTokenResponse.getToken()));
+                    update.setZtUserId(StringUtils.defaultString(ztBaseInfoResponse.getZtUserId(),ztBaseInfoResponse.getToken()));
+                    update.setToken(member.getToken());
                     update.setToken(member.getToken());
                     update.setId(member.getId());
                     update.setAuthStatus(member.getAuthStatus());
@@ -335,7 +334,6 @@
     public AccountResponse testLogin(String openid){
             String openId = openid;
             Member member = memberMapper.selectOne(new QueryWrapper<Member>().eq("OPENID", openId));
-
             if (member == null) {
                 member = new Member();
                 member.setNickname("寰俊鐢ㄦ埛"+ CodeVerifyUtils.createVerificationCode(4));
@@ -454,7 +452,9 @@
             //鏈粦瀹氳繃
             if (Objects.isNull(customerUser.getId())) {
                 customerUserMapper.insert(customerUser);
+                member.setAuthStatus(Constants.TWO);
             } else if(ztBaseResponse !=null) {
+                member.setAuthStatus(Constants.TWO);
                 customerUserMapper.updateById(customerUser);
             }
         }
@@ -518,7 +518,7 @@
         } catch (Exception e) {
             e.printStackTrace();
         }
-        throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏇存柊鎵嬫満鍙峰け璐�");
+        throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鑾峰彇鎵嬫満鍙峰け璐�");
     }
 
 
@@ -537,6 +537,14 @@
         if(!Objects.isNull(ztUserGetTokenResponse)){
             member.setToken(ztUserGetTokenResponse.getToken());
             member.setZtUserId(StringUtils.defaultString(ztUserGetTokenResponse.getZtUserId(),ztUserGetTokenResponse.getToken()));
+        }
+        if(StringUtils.isNotBlank(member.getPhone())){
+            if(!Constants.equalsInteger(member.getPhone().length(),11)){
+                throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鎵嬫満鍙烽敊璇�!");
+            }
+            if(Constants.equalsInteger(member.getAuthStatus(),Constants.ZERO)){
+                member.setAuthStatus(Constants.ONE);
+            }
         }
         memberMapper.updateById(member);
         return this.getMemberInfo(member.getId());
@@ -560,18 +568,19 @@
         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{
+        if(!Objects.isNull(ztUserGetTokenResponse)){
             member.setToken(ztUserGetTokenResponse.getToken());
-            member.setToken(StringUtils.defaultString(ztUserGetTokenResponse.getZtUserId(),ztUserGetTokenResponse.getToken()));
+            member.setZtUserId(StringUtils.defaultString(ztUserGetTokenResponse.getZtUserId(),ztUserGetTokenResponse.getToken()));
+        }
+        if(Constants.equalsInteger(member.getAuthStatus(),Constants.ZERO)){
+            memberDto.setAuthStatus(Constants.ONE);
         }
         memberMapper.updateById(memberDto);
         return this.getMemberInfo(member.getId());
     }
 
 
-    public ZTUserGetTokenResponse syncZhongTaiUser(Member member){
+    public static ZTUserGetTokenResponse syncZhongTaiUserNew(Member member,SystemDictDataBiz systemDictDataBiz,ZbomZhongTaiService zbomZhongTaiService){
         ZTUserInfoUpdateRequest ztUserInfoUpdateRequest = new  ZTUserInfoUpdateRequest();
         ztUserInfoUpdateRequest.setOpenId(member.getOpenid());
         String appId = systemDictDataBiz.queryByCode(Constants.WX_MINI_CONFIG,Constants.WX_APPID_CUSTOMER).getCode();
@@ -579,8 +588,15 @@
         ztUserInfoUpdateRequest.setPlatform(Constants.PLATFORM);
         ztUserInfoUpdateRequest.setPhone(member.getPhone());
         ztUserInfoUpdateRequest.setName(member.getName());
-        ztUserInfoUpdateRequest.setNickname(member.getNickname());
-//        ztUserInfoUpdateRequest.setAddress(member.getProvinceName()+member.getCityName()+member.getAreaName());
+        ztUserInfoUpdateRequest.setNickName(member.getNickname());
+        if(StringUtils.isNotBlank(member.getProvinceName())
+         && StringUtils.isNotBlank(member.getCityName())
+         && StringUtils.isNotBlank(member.getAreaName())){
+            ztUserInfoUpdateRequest.setAddress(member.getProvinceName()+member.getCityName()+member.getAreaName());
+        }
+        ztUserInfoUpdateRequest.setProvince(member.getProvinceCode());
+        ztUserInfoUpdateRequest.setCity(member.getCityCode());
+        ztUserInfoUpdateRequest.setCounty(member.getAreaCode());
         ztUserInfoUpdateRequest.setFullAddress(member.getAddress());
         String prefix = systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE, Constants.RESOURCE_PATH).getCode() +
                 systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE, Constants.MEMBER).getCode();
@@ -599,7 +615,7 @@
         ZTUserGetTokenResponse ztUserGetTokenResponse = (ZTUserGetTokenResponse) userUpdateInfo.getData();
         return ztUserGetTokenResponse;
     }
-    public static ZTUserGetTokenResponse syncZhongTaiUserNew(Member member,SystemDictDataBiz systemDictDataBiz,ZbomZhongTaiService zbomZhongTaiService){
+    public ZTUserGetTokenResponse syncZhongTaiUser(Member member){
         ZTUserInfoUpdateRequest ztUserInfoUpdateRequest = new  ZTUserInfoUpdateRequest();
         ztUserInfoUpdateRequest.setOpenId(member.getOpenid());
         String appId = systemDictDataBiz.queryByCode(Constants.WX_MINI_CONFIG,Constants.WX_APPID_CUSTOMER).getCode();
@@ -607,8 +623,17 @@
         ztUserInfoUpdateRequest.setPlatform(Constants.PLATFORM);
         ztUserInfoUpdateRequest.setPhone(member.getPhone());
         ztUserInfoUpdateRequest.setName(member.getName());
-        ztUserInfoUpdateRequest.setNickname(member.getNickname());
-//        ztUserInfoUpdateRequest.setAddress(member.getProvinceName()+member.getCityName()+member.getAreaName());
+        ztUserInfoUpdateRequest.setNickName(member.getNickname());
+
+        if(StringUtils.isNotBlank(member.getProvinceName())
+                && StringUtils.isNotBlank(member.getCityName())
+                && StringUtils.isNotBlank(member.getAreaName())){
+            ztUserInfoUpdateRequest.setAddress(member.getProvinceName()+member.getCityName()+member.getAreaName());
+        }
+        ztUserInfoUpdateRequest.setProvince(member.getProvinceCode());
+        ztUserInfoUpdateRequest.setCity(member.getCityCode());
+        ztUserInfoUpdateRequest.setCounty(member.getAreaCode());
+
         ztUserInfoUpdateRequest.setFullAddress(member.getAddress());
         String prefix = systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE, Constants.RESOURCE_PATH).getCode() +
                 systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE, Constants.MEMBER).getCode();

--
Gitblit v1.9.3