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/MemberServiceImpl.java |   92 +++++++++++++++++++++++++++++++--------------
 1 files changed, 63 insertions(+), 29 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 494e1bf..ca0bd68 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
@@ -300,14 +300,14 @@
                     member.setToken(ztUserGetTokenResponse.getToken());
                 }
                 memberMapper.insert(member);
-                MemberServiceImpl.saveCustomerUser(zbomZhongTaiService,customerUserMapper,users,member.getId(),member.getOpenid());
+                MemberServiceImpl.saveCustomerUser(zbomZhongTaiService,customerUserMapper,users,member);
             }else{
-                ZTUserGetTokenResponse ztUserGetTokenResponse = this.syncZhongTaiUser(member);
-                if(!Objects.isNull(ztUserGetTokenResponse)){
-                    member.setToken(ztUserGetTokenResponse.getToken());
+                ZTBaseInfoResponse ztBaseInfoResponse = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,member.getId(),ZTConstants.CUSTOMER);
+                if(!Objects.isNull(ztBaseInfoResponse)){
+                    member.setToken(ztBaseInfoResponse.getToken());
                     memberMapper.updateById(member);
                 }
-                MemberServiceImpl.saveCustomerUser(zbomZhongTaiService,customerUserMapper,users,member.getId(),member.getOpenid());
+                MemberServiceImpl.saveCustomerUser(zbomZhongTaiService,customerUserMapper,users,member);
                 member = this.getMemberInfo(member.getId());
             }
             String token = JwtTokenUtil.generateTokenForZb(member.getId(),ZTConstants.CUSTOMER, JSONObject.toJSON(member).toString(),redisTemplate);
@@ -326,7 +326,7 @@
     @Override
     public AccountResponse testLogin(String openid){
             String openId = openid;
-            Member member = memberMapper.selectOne(new QueryWrapper<Member>().eq("OPENID", openId).isNotNull("phone"));
+            Member member = memberMapper.selectOne(new QueryWrapper<Member>().eq("OPENID", openId));
 
             if (member == null) {
                 member = new Member();
@@ -357,32 +357,59 @@
             return accountResponse;
     }
 
-    public static void saveCustomerUser(ZbomZhongTaiService zbomZhongTaiService,CustomerUserMapper customerUserMapper,Users users,Long memberId,String openId){
-        if(Objects.nonNull(users)&&Objects.nonNull(memberId)) {
+    public static void saveCustomerUser(ZbomZhongTaiService zbomZhongTaiService,CustomerUserMapper customerUserMapper,Users users,Member member){
+        if(Objects.nonNull(users)&&Objects.nonNull(member.getId())) {
+            CustomerUser customerUser = null;
             if (customerUserMapper.selectCount(new QueryWrapper<CustomerUser>().lambda()
                     .eq(CustomerUser::getIsdeleted, Constants.ZERO)
                     .eq(CustomerUser::getUserId, users.getId())
-                    .eq(CustomerUser::getMemberId, memberId)) <= Constants.ZERO) {
-                CustomerUser customerUser = new CustomerUser();
+                    .eq(CustomerUser::getMemberId, member.getId())) <= Constants.ZERO) {
+                customerUser = new CustomerUser();
+                customerUser.setIsdeleted(Constants.ZERO);
                 customerUser.setUserId(users.getId());
                 customerUser.setCreateDate(new Date());
-                customerUser.setMemberId(memberId);
+                customerUser.setMemberId(member.getId());
                 customerUser.setPhone(users.getPhone());
                 customerUser.setIamUserId(users.getIamId());
                 customerUser.setName(users.getName());
                 customerUser.setUsername(users.getIamUsername());
                 customerUser.setAddr(users.getShopAddress());
+            }
+            //绛夊緟璋冭捣涓彴鎺ュ彛
+            ZTCustomerBindingUsersRequest ztCustomerBindingUsersRequest = new ZTCustomerBindingUsersRequest();
+            ztCustomerBindingUsersRequest.setName(member.getName());
+            ztCustomerBindingUsersRequest.setNickName(member.getNickname());
+            ztCustomerBindingUsersRequest.setPhone(member.getPhone());
+            ztCustomerBindingUsersRequest.setAvatarUrl(member.getImgurl());
+            ztCustomerBindingUsersRequest.setUptown(member.getDistrict());
+            ztCustomerBindingUsersRequest.setFullAddress(member.getAddress());
+            if(Objects.nonNull(member.getHousearea())){
+                ztCustomerBindingUsersRequest.setHouseArea(member.getHousearea().toString());
+            }
+            ztCustomerBindingUsersRequest.setOpenId(member.getOpenid());
+            ztCustomerBindingUsersRequest.setToken(member.getToken());
+            ztCustomerBindingUsersRequest.setUserType(ZTConstants.CUSTOMER);
+            ztCustomerBindingUsersRequest.setSourceCustomerId(member.getId().toString());
+            ztCustomerBindingUsersRequest.setDaoGouUserId(users.getIamId());
+            ztCustomerBindingUsersRequest.setDaoGouAccount(users.getIamUsername());
+            ztCustomerBindingUsersRequest.setPlatSource("2");
+            ZTBaseResponse ztBaseResponse = zbomZhongTaiService.customerBinDingUsers(ztCustomerBindingUsersRequest);
+            if(Objects.nonNull(customerUser)){
+                if(Objects.nonNull(ztBaseResponse)){
+                    if(ztBaseResponse.getSuccess()){
+                        customerUser.setZtStatus(1);
+                        customerUser.setZtDate(new Date());
+                    }else{
+                        customerUser.setZtStatus(2);
+                        customerUser.setZtDate(new Date());
+                        customerUser.setZtInfo(JSONObject.toJSONString(ztBaseResponse));
+                    }
+                } else{
+                    customerUser.setZtStatus(2);
+                    customerUser.setZtDate(new Date());
+                    customerUser.setZtInfo(JSONObject.toJSONString(ztBaseResponse));
+                }
                 customerUserMapper.insert(customerUser);
-                //绛夊緟璋冭捣涓彴鎺ュ彛
-                ZTCustomerBindingUsersRequest ztCustomerBindingUsersRequest = new ZTCustomerBindingUsersRequest();
-                ztCustomerBindingUsersRequest.setOpenId(openId);
-                ztCustomerBindingUsersRequest.setSourceCustomerId(memberId.toString());
-                ztCustomerBindingUsersRequest.setDaoGouUserId(users.getId().toString());
-                ztCustomerBindingUsersRequest.setDaoGouAccount(users.getIamUsername());
-                ztCustomerBindingUsersRequest.setDaoGouType(users.getUserTypes());
-                ztCustomerBindingUsersRequest.setUserName(users.getIamId());
-                ztCustomerBindingUsersRequest.setPlatSource(ZTConstants.PLATFORM_MP_WX);
-                zbomZhongTaiService.customerBinDingUsers(ztCustomerBindingUsersRequest);
             }
         }
     }
@@ -415,20 +442,26 @@
         if(Objects.isNull(editMemberRequest)){
             throw new BusinessException(ResponseStatus.BAD_REQUEST);
         }
-        Member memberDto = new Member();
-        BeanUtils.copyProperties(editMemberRequest,memberDto);
-        memberDto.setOpenid(member.getOpenid());
-        memberMapper.updateById(memberDto);
+        BeanUtils.copyProperties(editMemberRequest,member);
+        memberMapper.updateById(member);
+        //鍚屾涓彴鐢ㄦ埛淇℃伅
+        ZTUserGetTokenResponse ztUserGetTokenResponse = this.syncZhongTaiUser(member);
+        if(!Objects.isNull(ztUserGetTokenResponse)){
+            member.setToken(ztUserGetTokenResponse.getToken());
+        }
         return this.getMemberInfo(member.getId());
     }
-
-
 
     @Override
     public Member updMemberPhone(EditMemberRequest editMemberRequest){
         if(Objects.isNull(editMemberRequest)||StringUtils.isBlank(editMemberRequest.getPhone())){
             throw new BusinessException(ResponseStatus.BAD_REQUEST);
         }
+        memberMapper.update(null,new UpdateWrapper<Member>().lambda().set(Member::getPhone,null)
+                .set(Member::getEditDate,new Date())
+                .ne(Member::getId,editMemberRequest.getId())
+                .eq(Member::getPhone,editMemberRequest.getPhone()));
+
         Member member = memberMapper.selectById(editMemberRequest.getId());
         if(Objects.isNull(member)){
             throw new BusinessException(ResponseStatus.DATA_EMPTY);
@@ -454,7 +487,8 @@
         ztUserInfoUpdateRequest.setAppId(appId);
         ztUserInfoUpdateRequest.setPlatform(Constants.PLATFORM);
         ztUserInfoUpdateRequest.setPhone(member.getPhone());
-        ztUserInfoUpdateRequest.setName(member.getNickname());
+        ztUserInfoUpdateRequest.setName(member.getName());
+        ztUserInfoUpdateRequest.setNickname(member.getNickname());
 //        ztUserInfoUpdateRequest.setAddress(member.getProvinceName()+member.getCityName()+member.getAreaName());
         ztUserInfoUpdateRequest.setFullAddress(member.getAddress());
         String prefix = systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE, Constants.RESOURCE_PATH).getCode() +
@@ -485,7 +519,7 @@
                 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){
+                .lambda().eq(CustomerUser::getIsdeleted,Constants.ZERO).eq(CustomerUser::getZtStatus,Constants.ONE).eq(CustomerUser::getMemberId,member.getId()))>0){
             member.setAuthStatus(Constants.TWO);
         }else{
             if(StringUtils.isBlank(member.getPhone())){

--
Gitblit v1.9.3