From 9aa4f105dd7c4b9e576bebc8e01bb21c366ce550 Mon Sep 17 00:00:00 2001
From: liukangdong <898885815@qq.com>
Date: 星期五, 02 八月 2024 11:09:31 +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/GetZhongTaiDataServiceImpl.java |   78 ++++++++++++++++++++++++++++-----------
 1 files changed, 56 insertions(+), 22 deletions(-)

diff --git a/server/service/src/main/java/com/doumee/service/business/impl/GetZhongTaiDataServiceImpl.java b/server/service/src/main/java/com/doumee/service/business/impl/GetZhongTaiDataServiceImpl.java
index a57de5b..5769170 100644
--- a/server/service/src/main/java/com/doumee/service/business/impl/GetZhongTaiDataServiceImpl.java
+++ b/server/service/src/main/java/com/doumee/service/business/impl/GetZhongTaiDataServiceImpl.java
@@ -287,10 +287,15 @@
         ZTProductInfoResponse response = zbomZhongTaiService.getProductInfo(ztContentListRequest);
         if(Objects.nonNull(response)){
             //鏌ヨ瀵艰喘淇℃伅 杩涜淇℃伅缁戝畾涓庤繑鍥�
-            if(StringUtils.isNotBlank(salesId)){
+            if(StringUtils.isNotBlank(salesId)&&userType.equals(ZTConstants.CUSTOMER)){
                 Users users = usersMapper.selectById(salesId);
-                if(Objects.nonNull(users)){
-                    MemberServiceImpl.saveCustomerUser(customerUserMapper,users,userId);
+                Member member = memberMapper.selectById(userId);
+                if(StringUtils.isNotBlank(member.getImgurl())){
+                    member.setImgurl(systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE, Constants.RESOURCE_PATH).getCode() +
+                            systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE, Constants.MEMBER).getCode() + member.getImgurl());
+                }
+                if(Objects.nonNull(users)&&Objects.nonNull(member)&&StringUtils.isNotBlank(member.getOpenid())){
+                    MemberServiceImpl.saveCustomerUser(zbomZhongTaiService,customerUserMapper,users,member);
                     String prefix = StringUtils.trimToNull(systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE,Constants.RESOURCE_PATH).getCode()) +
                             StringUtils.trimToNull(systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE,Constants.USERS_FILE).getCode());
                     if(StringUtils.isNotBlank(users.getImgurl())){
@@ -338,16 +343,16 @@
         ztContentListRequest.setId(id);
         ZTCaseInfoResponse response = zbomZhongTaiService.getWholecaseInfo(ztContentListRequest);
         if(Objects.nonNull(response)){
-//            if(StringUtils.isNotBlank(response.getPanorama())){
-//                response.setPanorama(
-//                        response.getPanorama().replace("https://720.","https://720-3.").replace("https://720-2.","https://720-3.")
-//                );
-//            }
             //鏌ヨ瀵艰喘淇℃伅 杩涜淇℃伅缁戝畾涓庤繑鍥�
-            if(StringUtils.isNotBlank(salesId)){
+            if(StringUtils.isNotBlank(salesId)&&userType.equals(ZTConstants.CUSTOMER)){
                 Users users = usersMapper.selectById(salesId);
-                if(Objects.nonNull(users)){
-                    MemberServiceImpl.saveCustomerUser(customerUserMapper,users,userId);
+                Member member = memberMapper.selectById(userId);
+                if(StringUtils.isNotBlank(member.getImgurl())){
+                    member.setImgurl(systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE, Constants.RESOURCE_PATH).getCode() +
+                            systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE, Constants.MEMBER).getCode() + member.getImgurl());
+                }
+                if(Objects.nonNull(users)&&Objects.nonNull(member)&&StringUtils.isNotBlank(member.getOpenid())){
+                    MemberServiceImpl.saveCustomerUser(zbomZhongTaiService,customerUserMapper,users,member);
                     String prefix = StringUtils.trimToNull(systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE,Constants.RESOURCE_PATH).getCode()) +
                             StringUtils.trimToNull(systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE,Constants.USERS_FILE).getCode());
                     if(StringUtils.isNotBlank(users.getImgurl())){
@@ -390,10 +395,15 @@
         ZTProductNewsInfoResponse response = zbomZhongTaiService.getProductNewsInfo(ztContentListRequest);
         if(Objects.nonNull(response)){
             //鏌ヨ瀵艰喘淇℃伅 杩涜淇℃伅缁戝畾涓庤繑鍥�
-            if(StringUtils.isNotBlank(salesId)){
+            if(StringUtils.isNotBlank(salesId)&&userType.equals(ZTConstants.CUSTOMER)){
                 Users users = usersMapper.selectById(salesId);
-                if(Objects.nonNull(users)){
-                    MemberServiceImpl.saveCustomerUser(customerUserMapper,users,userId);
+                Member member = memberMapper.selectById(userId);
+                if(StringUtils.isNotBlank(member.getImgurl())){
+                    member.setImgurl(systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE, Constants.RESOURCE_PATH).getCode() +
+                            systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE, Constants.MEMBER).getCode() + member.getImgurl());
+                }
+                if(Objects.nonNull(users)&&Objects.nonNull(member)&&StringUtils.isNotBlank(member.getOpenid())){
+                    MemberServiceImpl.saveCustomerUser(zbomZhongTaiService,customerUserMapper,users,member);
                     String prefix = StringUtils.trimToNull(systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE,Constants.RESOURCE_PATH).getCode()) +
                             StringUtils.trimToNull(systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE,Constants.USERS_FILE).getCode());
                     if(StringUtils.isNotBlank(users.getImgurl())){
@@ -441,10 +451,15 @@
         ZTRealcaseInfoResponse response = zbomZhongTaiService.getRealcaseInfo(ztContentListRequest);
         if(Objects.nonNull(response)){
             //鏌ヨ瀵艰喘淇℃伅 杩涜淇℃伅缁戝畾涓庤繑鍥�
-            if(StringUtils.isNotBlank(salesId)){
+            if(StringUtils.isNotBlank(salesId)&&userType.equals(ZTConstants.CUSTOMER)){
                 Users users = usersMapper.selectById(salesId);
-                if(Objects.nonNull(users)){
-                    MemberServiceImpl.saveCustomerUser(customerUserMapper,users,userId);
+                Member member = memberMapper.selectById(userId);
+                if(Objects.nonNull(users)&&Objects.nonNull(member)&&StringUtils.isNotBlank(member.getOpenid())){
+                    if(StringUtils.isNotBlank(member.getImgurl())){
+                        member.setImgurl(systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE, Constants.RESOURCE_PATH).getCode() +
+                                systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE, Constants.MEMBER).getCode() + member.getImgurl());
+                    }
+                    MemberServiceImpl.saveCustomerUser(zbomZhongTaiService,customerUserMapper,users,member);
                     String prefix = StringUtils.trimToNull(systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE,Constants.RESOURCE_PATH).getCode()) +
                             StringUtils.trimToNull(systemDictDataBiz.queryByCode(Constants.OBJCET_STORAGE,Constants.USERS_FILE).getCode());
                     if(StringUtils.isNotBlank(users.getImgurl())){
@@ -489,8 +504,7 @@
     public void batchAddLike(ZTBatchAddListRequest ztBatchAddListRequest){
         if(Objects.isNull(ztBatchAddListRequest)
                 || StringUtils.isBlank(ztBatchAddListRequest.getArticleIds())
-                || StringUtils.isBlank(ztBatchAddListRequest.getCustomerId())
-                || StringUtils.isBlank(ztBatchAddListRequest.getPlatSourceId())
+                || StringUtils.isBlank(ztBatchAddListRequest.getPlatId())
                 || StringUtils.isBlank(ztBatchAddListRequest.getPlatSource())
         ){
             throw new BusinessException(ResponseStatus.BAD_REQUEST);
@@ -499,9 +513,29 @@
         ZTBaseInfoResponse ztBaseInfoResponse = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,
                 Long.valueOf(ztBatchAddListRequest.getUserId()),ztBatchAddListRequest.getUserType());
         ztBatchAddListRequest.setToken(ztBaseInfoResponse.getToken());
-        zbomZhongTaiService.batchAddLike(ztBatchAddListRequest);
+        ZTBaseResponse result = zbomZhongTaiService.batchAddLike(ztBatchAddListRequest);
+        if(result ==null || !Constants.equalsInteger( result.getCode(),ZTConstants.CODE_SUCCESS)){
+            throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"瀵逛笉璧凤紝鍒嗕韩缁戝畾澶辫触鍝︼紒");
+        }
     }
 
-
-
+    @Override
+    public void customerBinDingUsers(ZTCustomerBindingUsersRequest ztCustomerBindingUsersRequest){
+        if(Objects.isNull(ztCustomerBindingUsersRequest)
+                || StringUtils.isBlank(ztCustomerBindingUsersRequest.getOpenId())
+                || StringUtils.isBlank(ztCustomerBindingUsersRequest.getUserId())
+                || StringUtils.isBlank(ztCustomerBindingUsersRequest.getSourceCustomerId())
+                || StringUtils.isBlank(ztCustomerBindingUsersRequest.getDaoGouAccount())
+                || StringUtils.isBlank(ztCustomerBindingUsersRequest.getDaoGouType())
+                || StringUtils.isBlank(ztCustomerBindingUsersRequest.getDaoGouUserId())
+                || StringUtils.isBlank(ztCustomerBindingUsersRequest.getUserName())
+        ){
+            throw new BusinessException(ResponseStatus.BAD_REQUEST);
+        }
+        //鏌ヨ 涓彴
+        ZTBaseInfoResponse ztBaseInfoResponse = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,
+                Long.valueOf(ztCustomerBindingUsersRequest.getUserId()),ztCustomerBindingUsersRequest.getUserType());
+        ztCustomerBindingUsersRequest.setToken(ztBaseInfoResponse.getToken());
+        zbomZhongTaiService.customerBinDingUsers(ztCustomerBindingUsersRequest);
+    }
 }

--
Gitblit v1.9.3