From b5c218b2ed749a3e710c92c4770759773de4fc0c Mon Sep 17 00:00:00 2001
From: k94314517 <8417338+k94314517@user.noreply.gitee.com>
Date: 星期四, 01 八月 2024 18:25:19 +0800
Subject: [PATCH] 代码提交

---
 server/service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java |  145 ++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 116 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 4884ee5..e512566 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
@@ -357,13 +357,75 @@
             return accountResponse;
     }
 
-    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()
+//    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, member.getId())
+//            ) <= Constants.ZERO) {
+//                customerUser = new CustomerUser();
+//                customerUser.setIsdeleted(Constants.ZERO);
+//                customerUser.setUserId(users.getId());
+//                customerUser.setCreateDate(new Date());
+//                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);
+//            }
+//        }
+//    }
+
+
+    public static void saveCustomerUser(ZbomZhongTaiService zbomZhongTaiService, CustomerUserMapper customerUserMapper, Users users, Member member) {
+        if (Objects.nonNull(users) && Objects.nonNull(member.getId())) {
+            CustomerUser customerUser = customerUserMapper.selectOne(new QueryWrapper<CustomerUser>().lambda()
                     .eq(CustomerUser::getIsdeleted, Constants.ZERO)
                     .eq(CustomerUser::getUserId, users.getId())
-                    .eq(CustomerUser::getMemberId, member.getId())) <= Constants.ZERO) {
+                    .eq(CustomerUser::getMemberId, member.getId())
+                    .orderByDesc(CustomerUser::getCreateDate)
+                    .last(" limit 1")
+            );
+            if (Objects.isNull(customerUser)) {
                 customerUser = new CustomerUser();
                 customerUser.setIsdeleted(Constants.ZERO);
                 customerUser.setUserId(users.getId());
@@ -375,46 +437,71 @@
                 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()){
+            //鏈粦瀹氳繃
+            if (Objects.isNull(customerUser.getId())) {
+                ZTBaseResponse ztBaseResponse = MemberServiceImpl.syncZtCustomerUser(zbomZhongTaiService,member, users);
+                if (Objects.nonNull(ztBaseResponse)) {
+                    if (ztBaseResponse.getSuccess()) {
                         customerUser.setZtStatus(1);
                         customerUser.setZtDate(new Date());
-                    }else{
+                    } else {
                         customerUser.setZtStatus(2);
                         customerUser.setZtDate(new Date());
                         customerUser.setZtInfo(JSONObject.toJSONString(ztBaseResponse));
                     }
-                } else{
+                } else {
                     customerUser.setZtStatus(2);
                     customerUser.setZtDate(new Date());
                     customerUser.setZtInfo(JSONObject.toJSONString(ztBaseResponse));
                 }
                 customerUserMapper.insert(customerUser);
+            } else {
+                if (!Constants.equalsInteger(customerUser.getZtStatus(),Constants.ONE)) {
+                    ZTBaseResponse ztBaseResponse = MemberServiceImpl.syncZtCustomerUser(zbomZhongTaiService,member, users);
+                    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.updateById(customerUser);
+                }
             }
         }
     }
 
 
+    public  static ZTBaseResponse syncZtCustomerUser(ZbomZhongTaiService zbomZhongTaiService,Member member,Users users){
+        //绛夊緟璋冭捣涓彴鎺ュ彛
+        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);
+        return ztBaseResponse;
+    }
+
     @Override
     public String getWxMiniPhone(WxPhoneRequest wxPhoneRequest){
         try {

--
Gitblit v1.9.3