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/GetZhongTaiDataServiceImpl.java |  622 ++++++++++++++++++++++++++++++++++++++------------------
 1 files changed, 418 insertions(+), 204 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 1de097f..7e2137b 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
@@ -9,10 +9,14 @@
 import com.doumee.core.constants.ResponseStatus;
 import com.doumee.core.exception.BusinessException;
 import com.doumee.core.utils.Constants;
+import com.doumee.core.utils.DateUtil;
+import com.doumee.dao.business.CustomerUserMapper;
 import com.doumee.dao.business.IamInterfaceLogMapper;
 import com.doumee.dao.business.MemberMapper;
 import com.doumee.dao.business.UsersMapper;
 import com.doumee.dao.business.model.Member;
+import com.doumee.dao.business.model.Users;
+import com.doumee.dao.web.response.ZSZXCatalogResponse;
 import com.doumee.dao.web.response.ZTBaseInfoResponse;
 import com.doumee.service.business.GetZhongTaiDataService;
 import com.github.xiaoymin.knife4j.core.util.CollectionUtils;
@@ -24,9 +28,7 @@
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Objects;
+import java.util.*;
 
 /**
  * Created by IntelliJ IDEA.
@@ -50,9 +52,34 @@
     private SystemDictDataBiz systemDictDataBiz;
 
     @Autowired
+    private CustomerUserMapper customerUserMapper;
+
+    @Autowired
     private RedisTemplate<String, Object> redisTemplate;
 
-
+    @Override
+    public ZSZXCatalogResponse getZSZXCatalogs(Long userId,String userType){
+        ZSZXCatalogResponse response = new ZSZXCatalogResponse();
+        ZTCatalogListRequest param = new ZTCatalogListRequest();
+        param.setUserId(userId.toString());
+        param.setUserType(userType);
+        param.setCatalogCode(ZTConstants.CatalogCode.ZHISHUO_ZHUANGXIU);
+        List<ZTCatalogInfoResponse> cataList = getCatalogList(param);
+        if(cataList!=null ){
+            for(ZTCatalogInfoResponse data : cataList){
+                if(StringUtils.equals(data.getCode(), ZTConstants.CatalogCode.JIADE_ID)){
+                    response.setJdId(data);
+                }else if(StringUtils.equals(data.getCode(), ZTConstants.CatalogCode.CHUFANGSHEJI)){
+                    response.setCfsj(data);
+                }else if(StringUtils.equals(data.getCode(), ZTConstants.CatalogCode.QW_SHEJI)){
+                    response.setQwsj(data);
+                }else if(StringUtils.equals(data.getCode(), ZTConstants.CatalogCode.SHOUNASHEJI)){
+                    response.setSnsj(data);
+                }
+            }
+        }
+        return response;
+    }
 
     @Override
     public List<ZTCatalogInfoResponse> getCatalogList(ZTCatalogListRequest ztCatalogListRequest){
@@ -60,14 +87,10 @@
         || StringUtils.isBlank(ztCatalogListRequest.getCatalogCode())){
             throw new BusinessException(ResponseStatus.BAD_REQUEST);
         }
-        if(!(ztCatalogListRequest.getCatalogCode().equals(ZTConstants.CatalogCode.CHANPING)
-            ||ztCatalogListRequest.getCatalogCode().equals(ZTConstants.CatalogCode.ZIXUN)
-            ||ztCatalogListRequest.getCatalogCode().equals(ZTConstants.CatalogCode.QW_CASE)
-                ||ztCatalogListRequest.getCatalogCode().equals(ZTConstants.CatalogCode.CAROUSEL_AD)
-                ||ztCatalogListRequest.getCatalogCode().equals(ZTConstants.CatalogCode.VIDEO_REC)
-                ||ztCatalogListRequest.getCatalogCode().equals(ZTConstants.CatalogCode.REAL_CASE))){
-            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鍒嗙被淇℃伅閿欒");
-        }
+        ZTBaseInfoResponse ztBaseInfoResponse  =  MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,Long.valueOf(ztCatalogListRequest.getUserId()),ztCatalogListRequest.getUserType());
+        System.out.println(JSONObject.toJSONString(ztBaseInfoResponse));
+        ztCatalogListRequest.setOpenId(ztBaseInfoResponse.getOpenId());
+        ztCatalogListRequest.setToken(ztBaseInfoResponse.getToken());
         return zbomZhongTaiService.getCatalogList(ztCatalogListRequest);
     }
 
@@ -78,206 +101,24 @@
                 || StringUtils.isBlank(ztCatalogListRequest.getCatalogCode())){
             throw new BusinessException(ResponseStatus.BAD_REQUEST);
         }
+        ZTBaseInfoResponse ztBaseInfoResponse  =  MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,Long.valueOf(ztCatalogListRequest.getUserId()),ztCatalogListRequest.getUserType());
+        ztCatalogListRequest.setOpenId(ztBaseInfoResponse.getOpenId());
+        ztCatalogListRequest.setToken(ztBaseInfoResponse.getToken());
         return zbomZhongTaiService.getTagList(ztCatalogListRequest);
     }
 
 
-    /**
-     *  鑾峰彇鐖跺瓙绾х粨鏋勬暟鎹垪琛�
-     * 蹇楄瑁呬慨 zb_deco 浜у搧 product_intro 璧勮product_info 鍏ㄥ眿妗堜緥 whole_case
-     * 鑾峰彇鐖跺瓙绾х粨鏋勬暟鎹�
-     * @return
-     */
-   /* @Override
-    public List<ZTCatalogInfoResponse> getZTCatalogInfoResponse(ZTCatalogListRequest ztCatalogListRequest){
-        if(Objects.isNull(ztCatalogListRequest)
-                || StringUtils.isBlank(ztCatalogListRequest.getCatalogCode())){
-            throw new BusinessException(ResponseStatus.BAD_REQUEST);
-        }
-        if(ztCatalogListRequest.getCatalogCode().equals(ZTConstants.CatalogCode.ZHISHUO_ZHUANGXIU)
-                ||ztCatalogListRequest.getCatalogCode().equals(ZTConstants.CatalogCode.CHANPING)
-                ||ztCatalogListRequest.getCatalogCode().equals(ZTConstants.CatalogCode.ZIXUN)
-                ||ztCatalogListRequest.getCatalogCode().equals(ZTConstants.CatalogCode.QW_CASE)){
-            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鍒嗙被淇℃伅閿欒");
-        }
-        List<ZTCatalogInfoResponse>  ztCatalogInfoResponseList = zbomZhongTaiService.getCatalogList(ztCatalogListRequest);
-        if(CollectionUtils.isNotEmpty(ztCatalogInfoResponseList)){
-            for (ZTCatalogInfoResponse ztCatalogInfoResponse:ztCatalogInfoResponseList) {
-                ZTCatalogListRequest ztCatalogTagListRequest = new ZTCatalogListRequest();
-                ztCatalogTagListRequest.setCatalogCode(ztCatalogInfoResponse.getCode());
-                List<ZTTagInfoResponse> ztTagInfoResponseList = zbomZhongTaiService.getTagList(ztCatalogTagListRequest);
-                if(CollectionUtils.isNotEmpty(ztCatalogInfoResponseList)){
-                    ztCatalogInfoResponse.setChildTagList(ztTagInfoResponseList);
-                }
-            }
-        }
-        return ztCatalogInfoResponseList;
-    }*/
-
-
-    /**
-     * 鍐呭 鍒嗛〉鏁版嵁
-     * @param ztContentListRequest
-     * @return
-     */
     @Override
-    public ZTBasePageResponse<ZTContentListResponse> pageContentList(ZTContentListRequest ztContentListRequest){
-        if(Objects.isNull(ztContentListRequest)
-            || Objects.isNull(ztContentListRequest.getPageNum())
-            || Objects.isNull(ztContentListRequest.getPageSize())
-            || StringUtils.isBlank(ztContentListRequest.getCatalogCode())
-        ){
-            throw new BusinessException(ResponseStatus.BAD_REQUEST);
-        }
-        //鏌ヨ 涓彴
-        ZTBaseInfoResponse ztBaseInfoResponse = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,
-                Long.valueOf(ztContentListRequest.getUserId()),ztContentListRequest.getUserType());
-        ztContentListRequest.setToken(ztBaseInfoResponse.getToken());
-        ZTBasePageResponse<ZTContentListResponse> response = zbomZhongTaiService.pageContentList(ztContentListRequest);
-
-        List<ZTContentListResponse> ztContentListResponseList = new ArrayList<>();
-
-        ZTContentListResponse ztContentListResponse = new ZTContentListResponse();
-        ztContentListResponse.setAuthor("娴嬭瘯浜哄憳");
-        ztContentListResponse.setCoverImage("https://yjszhfn.jiangsu-10.zos.ctyun.cn/news/20240711/16f0490c-3ab1-4b66-aad8-be167476572c.jpg");
-        ztContentListResponse.setFavoriteCount(1998);
-        ztContentListResponse.setLikeCount(2223);
-        ztContentListResponse.setPublishDepartment("娴嬭瘯缁勭粐");
-        ztContentListResponse.setReadCount(10209);
-        ztContentListResponse.setId("1");
-        ztContentListResponse.setTitle("鎴戞槸鏍囬浣犲ソ鍟�");
-        ztContentListResponse.setSubtitle("鎴戞槸鍓爣棰樹綘浠ソ鍟�");
-        if(CollectionUtils.isNotEmpty(response.getRecords())){
-            ztContentListResponseList.add(ztContentListResponse);
-            response.setRecords(ztContentListResponseList);
-        }else{
-            response.getRecords().add(0, ztContentListResponse);
-        }
-        return response;
-    }
-
-
-
-
-
-
-    @Override
-    public ZTContentInfoResponse getContentInfo(String id,String userType,Long userId){
-        //鏌ヨ 涓彴 TOKEN
-        ZTBaseInfoResponse ztBaseInfoResponse  = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,userId,userType);
-        ZTContentInfoRequest ztContentListRequest = new ZTContentInfoRequest();
-        ztContentListRequest.setToken(ztBaseInfoResponse.getToken());
-        ztContentListRequest.setUserType(ztBaseInfoResponse.getUserType());
-        ztContentListRequest.setId(id);
-        ZTContentInfoResponse response = zbomZhongTaiService.getContentInfo(ztContentListRequest);
-        if(Objects.isNull(response)){
-            response = new ZTContentInfoResponse();
-            response.setAuthor("娴嬭瘯浜哄憳");
-//            response.set("https://yjszhfn.jiangsu-10.zos.ctyun.cn/news/20240711/16f0490c-3ab1-4b66-aad8-be167476572c.jpg");
-//            response.setFavoriteCount(1998);
-//            response.setLikeCount(2223);
-            response.setPublishDepartment("娴嬭瘯缁勭粐");
-//            response.setReadCount(10209);
-            response.setTitle("鎴戞槸鏍囬浣犲ソ鍟�");
-            response.setPicUrls("https://yjszhfn.jiangsu-10.zos.ctyun.cn/news/20240711/16f0490c-3ab1-4b66-aad8-be167476572c.jpg");
-            response.setSubtitle("鎴戞槸鍓爣棰樹綘浠ソ鍟�");
-        }
-        return response;
-    }
-
-    @Override
-    public void collectContent(Long userId,String userType,String articleId){
+    public void actionDo(Long userId,String userType,String articleId,String actionType){
         ZTBaseInfoResponse ztBaseInfoResponse  =  MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,userId,userType);
         ZTActionDoRequest param = new ZTActionDoRequest();
         param.setOpenId(ztBaseInfoResponse.getOpenId());
         param.setUserType(userType);
         param.setArticleId(articleId);
         param.setToken(ztBaseInfoResponse.getToken());
-        ZTBaseResponse ztBaseResponse =  zbomZhongTaiService.collectDo(param);
-        if(Objects.isNull(ztBaseResponse)){
-            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"涓彴鎺ュ彛鍝嶅簲澶辫触");
-        }else{
-            if(!ztBaseResponse.getSuccess()){
-                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"涓彴璇锋眰淇℃伅寮傚父锛�"+ztBaseResponse.getMsg());
-            }
-        }
+        param.setActionType(actionType);
+        zbomZhongTaiService.collectDo(param);
     }
-
-    @Override
-    public void likeContent(Long userId,String userType,String articleId){
-        ZTBaseInfoResponse ztBaseInfoResponse  =  MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,userId,userType);
-        ZTActionBatchDoRequest param = new ZTActionBatchDoRequest();
-        param.setOpenId(ztBaseInfoResponse.getOpenId());
-        param.setUserType(userType);
-        param.setToken(ztBaseInfoResponse.getToken());
-        List<ZTActionDoRequest> list = new ArrayList<>();
-        ZTActionDoRequest ztActionDoRequest = new ZTActionDoRequest();
-        ztActionDoRequest.setArticleId(articleId);
-        param.setList(list);
-        ZTBaseResponse ztBaseResponse =  zbomZhongTaiService.likeDo(param);
-        if(Objects.isNull(ztBaseResponse)){
-            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"涓彴鎺ュ彛鍝嶅簲澶辫触");
-        }else{
-            if(!ztBaseResponse.getSuccess()){
-                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"涓彴璇锋眰淇℃伅寮傚父锛�"+ztBaseResponse.getMsg());
-            }
-        }
-    }
-
-
-    @Override
-    public void shareContent(Long userId,String userType,String articleId){
-        ZTBaseInfoResponse ztBaseInfoResponse  =  MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,userId,userType);
-        ZTActionDoRequest param = new ZTActionDoRequest();
-        param.setArticleId(articleId);
-        param.setOpenId(ztBaseInfoResponse.getOpenId());
-        param.setUserType(userType);
-        param.setToken(ztBaseInfoResponse.getToken());
-        ZTBaseResponse ztBaseResponse =  zbomZhongTaiService.shareDo(param);
-        if(Objects.isNull(ztBaseResponse)){
-            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"涓彴鎺ュ彛鍝嶅簲澶辫触");
-        }else{
-            if(!ztBaseResponse.getSuccess()){
-                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"涓彴璇锋眰淇℃伅寮傚父锛�"+ztBaseResponse.getMsg());
-            }
-        }
-    }
-
-
-    @Override
-    public void viewContent(Long userId,String userType,String articleId){
-        ZTBaseInfoResponse ztBaseInfoResponse  =  MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,userId,userType);
-        ZTActionDoRequest param = new ZTActionDoRequest();
-        param.setArticleId(articleId);
-        param.setOpenId(ztBaseInfoResponse.getOpenId());
-        param.setUserType(userType);
-        param.setToken(ztBaseInfoResponse.getToken());
-        ZTBaseResponse ztBaseResponse =  zbomZhongTaiService.viewDo(param);
-        if(Objects.isNull(ztBaseResponse)){
-            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"涓彴鎺ュ彛鍝嶅簲澶辫触");
-        }else{
-            if(!ztBaseResponse.getSuccess()){
-                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"涓彴璇锋眰淇℃伅寮傚父锛�"+ztBaseResponse.getMsg());
-            }
-        }
-    }
-
-//    public ZTBasePageResponse<ZTCollectInfoResponse> viewContent(Long userId,String userType,String articleId) {
-//        ZTBaseInfoResponse ztBaseInfoResponse = MemberServiceImpl.getZTToken(zbomZhongTaiService, memberMapper, usersMapper, systemDictDataBiz, userId, userType);
-//        ZTActionDoRequest param = new ZTActionDoRequest();
-//        param.setArticleId(articleId);
-//        param.setOpenId(ztBaseInfoResponse.getOpenId());
-//        param.setUserType(userType);
-//        param.setToken(ztBaseInfoResponse.getToken());
-//        ZTBaseResponse ztBaseResponse = zbomZhongTaiService.viewDo(param);
-//        if (Objects.isNull(ztBaseResponse)) {
-//            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "涓彴鎺ュ彛鍝嶅簲澶辫触");
-//        } else {
-//            if (!ztBaseResponse.getSuccess()) {
-//                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "涓彴璇锋眰淇℃伅寮傚父锛�" + ztBaseResponse.getMsg());
-//            }
-//        }
-//    }
 
     @Override
     public ZTBasePageResponse<ZTCusFavoritesInfoResponse> getZhongTaiCusFavorite(ZTContentListRequest ztContentListRequest){
@@ -287,9 +128,6 @@
         ZTBasePageResponse ztAreaTreeResponses = zbomZhongTaiService.pageCusFavoriteList(ztContentListRequest);
         return ztAreaTreeResponses;
     }
-
-
-
 
     @Override
     @Async
@@ -302,8 +140,13 @@
         String data = (String) redisTemplate.opsForValue().get(Constants.RedisKeys.ZBOM_AREA_REDIS_KEY);
         List<ZTAreaTreeResponse> ztAreaTreeResponses = new ArrayList<>();
         if(StringUtils.isBlank(data)){
+            ZTBaseInfoResponse ztBaseInfoResponse  =  MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,Long.valueOf(ztAreaListRequest.getUserId()),ztAreaListRequest.getUserType());
+            ztAreaListRequest.setOpenId(ztBaseInfoResponse.getOpenId());
+            ztAreaListRequest.setToken(ztBaseInfoResponse.getToken());
             ztAreaTreeResponses =  zbomZhongTaiService.getAreaTreeList(ztAreaListRequest);
-            redisTemplate.opsForValue().set(Constants.RedisKeys.ZBOM_AREA_REDIS_KEY,JSONArray.toJSONString(ztAreaTreeResponses));
+            if(CollectionUtils.isNotEmpty(ztAreaTreeResponses)){
+                redisTemplate.opsForValue().set(Constants.RedisKeys.ZBOM_AREA_REDIS_KEY,JSONArray.toJSONString(ztAreaTreeResponses));
+            }
         }else{
             ztAreaTreeResponses = JSONArray.parseArray(data,ZTAreaTreeResponse.class);
         }
@@ -329,4 +172,375 @@
     }
 
 
+
+    @Override
+    public ZTBasePageResponse<ZTProductNewsInfoResponse> getZhongTaiProductNewsPage(ZTContentListRequest ztContentListRequest){
+        if(Objects.isNull(ztContentListRequest)
+                || Objects.isNull(ztContentListRequest.getPageNum())
+                || Objects.isNull(ztContentListRequest.getPageSize())
+        ){
+            throw new BusinessException(ResponseStatus.BAD_REQUEST);
+        }
+        //鏌ヨ 涓彴
+        ZTBaseInfoResponse ztBaseInfoResponse = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,
+                Long.valueOf(ztContentListRequest.getUserId()),ztContentListRequest.getUserType());
+        ztContentListRequest.setToken(ztBaseInfoResponse.getToken());
+        ZTBasePageResponse<ZTProductNewsInfoResponse> response = zbomZhongTaiService.pageProductNewsList(ztContentListRequest);
+        return response;
+    }
+
+
+    @Override
+    public ZTBasePageResponse<ZTProductInfoResponse> getZhongTaiProductPage(ZTContentListRequest ztContentListRequest){
+        if(Objects.isNull(ztContentListRequest)
+                || Objects.isNull(ztContentListRequest.getPageNum())
+                || Objects.isNull(ztContentListRequest.getPageSize())
+        ){
+            throw new BusinessException(ResponseStatus.BAD_REQUEST);
+        }
+        //鏌ヨ 涓彴
+        ZTBaseInfoResponse ztBaseInfoResponse = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,
+                Long.valueOf(ztContentListRequest.getUserId()),ztContentListRequest.getUserType());
+        ztContentListRequest.setToken(ztBaseInfoResponse.getToken());
+        System.out.println("寮�濮嬫椂闂�========================銆�"+DateUtil.getLongDate(new Date()));
+        ZTBasePageResponse<ZTProductInfoResponse> response = zbomZhongTaiService.pageProductList(ztContentListRequest);
+        System.out.println("缁撴潫鏃堕棿========================銆�"+DateUtil.getLongDate(new Date()));
+        return response;
+    }
+
+
+    @Override
+    public ZTBasePageResponse<ZTRealcaseInfoResponse> getZhongTaiRealcasePage(ZTContentListRequest ztContentListRequest){
+        if(Objects.isNull(ztContentListRequest)
+                || Objects.isNull(ztContentListRequest.getPageNum())
+                || Objects.isNull(ztContentListRequest.getPageSize())
+        ){
+            throw new BusinessException(ResponseStatus.BAD_REQUEST);
+        }
+        //鏌ヨ 涓彴
+        ZTBaseInfoResponse ztBaseInfoResponse = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,
+                Long.valueOf(ztContentListRequest.getUserId()),ztContentListRequest.getUserType());
+        ztContentListRequest.setToken(ztBaseInfoResponse.getToken());
+        ZTBasePageResponse<ZTRealcaseInfoResponse> response = zbomZhongTaiService.pageRealcaseList(ztContentListRequest);
+        return response;
+    }
+
+
+    @Override
+    public ZTBasePageResponse<ZTVideoInfoResponse> getZhongTaiVideoPage(ZTContentListRequest ztContentListRequest){
+        if(Objects.isNull(ztContentListRequest)
+                || Objects.isNull(ztContentListRequest.getPageNum())
+                || Objects.isNull(ztContentListRequest.getPageSize())
+        ){
+            throw new BusinessException(ResponseStatus.BAD_REQUEST);
+        }
+        //鏌ヨ 涓彴
+        ZTBaseInfoResponse ztBaseInfoResponse = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,
+                Long.valueOf(ztContentListRequest.getUserId()),ztContentListRequest.getUserType());
+        ztContentListRequest.setToken(ztBaseInfoResponse.getToken());
+        ZTBasePageResponse<ZTVideoInfoResponse> response = zbomZhongTaiService.pageVideoList(ztContentListRequest);
+        return response;
+    }
+
+    @Override
+    public ZTBasePageResponse<ZTCaseInfoResponse> getZhongTaiWholecasePage(ZTContentListRequest ztContentListRequest){
+        if(Objects.isNull(ztContentListRequest)
+                || Objects.isNull(ztContentListRequest.getPageNum())
+                || Objects.isNull(ztContentListRequest.getPageSize())
+        ){
+            throw new BusinessException(ResponseStatus.BAD_REQUEST);
+        }
+        //鏌ヨ 涓彴
+        ZTBaseInfoResponse ztBaseInfoResponse = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,
+                Long.valueOf(ztContentListRequest.getUserId()),ztContentListRequest.getUserType());
+        ztContentListRequest.setToken(ztBaseInfoResponse.getToken());
+        ZTBasePageResponse<ZTCaseInfoResponse> response = zbomZhongTaiService.pageWholecaseList(ztContentListRequest);
+        return response;
+    }
+
+
+    @Override
+    public ZTBasePageResponse<ZTZbDecoInfoResponse> getZhongTaiZbDecoPage(ZTContentListRequest ztContentListRequest){
+        if(Objects.isNull(ztContentListRequest)
+                || Objects.isNull(ztContentListRequest.getPageNum())
+                || Objects.isNull(ztContentListRequest.getPageSize())
+        ){
+            throw new BusinessException(ResponseStatus.BAD_REQUEST);
+        }
+        //鏌ヨ 涓彴
+        ZTBaseInfoResponse ztBaseInfoResponse = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,
+                Long.valueOf(ztContentListRequest.getUserId()),ztContentListRequest.getUserType());
+        ztContentListRequest.setToken(ztBaseInfoResponse.getToken());
+        ZTBasePageResponse<ZTZbDecoInfoResponse> response = zbomZhongTaiService.pageZbDecoList(ztContentListRequest);
+        return response;
+    }
+
+
+    @Override
+    public ZTProductInfoResponse getProductInfo(String id,String userType,Long userId,String salesId){
+        //鏌ヨ 涓彴 TOKEN
+        ZTBaseInfoResponse ztBaseInfoResponse  = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,userId,userType);
+        ZTContentInfoRequest ztContentListRequest = new ZTContentInfoRequest();
+        ztContentListRequest.setToken(ztBaseInfoResponse.getToken());
+        ztContentListRequest.setUserType(ztBaseInfoResponse.getUserType());
+        ztContentListRequest.setId(id);
+        ZTProductInfoResponse response = zbomZhongTaiService.getProductInfo(ztContentListRequest);
+        if(Objects.nonNull(response)){
+            //鏌ヨ瀵艰喘淇℃伅 杩涜淇℃伅缁戝畾涓庤繑鍥�
+            if(StringUtils.isNotBlank(salesId)&&userType.equals(ZTConstants.CUSTOMER)){
+                Users users = usersMapper.selectById(salesId);
+                Member member = memberMapper.selectById(userId);
+                if(Objects.nonNull(users)&&Objects.nonNull(member)&&StringUtils.isNotBlank(member.getOpenid())){
+                    //鏇存柊瀵艰喘缁戝畾淇℃伅
+                    MemberServiceImpl.saveCustomerUser(zbomZhongTaiService,customerUserMapper,memberMapper,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())){
+                        users.setImgurlFull(prefix + users.getImgurl());
+                    }
+                    response.setUsers(users);
+                    memberMapper.updateById(member);
+                }
+                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());
+                }
+            }
+            List<String> stringList = new ArrayList<String>();
+            if (StringUtils.isNotBlank(response.getCoverImage())) {
+                stringList.add(response.getCoverImage());
+            }
+            if(Objects.nonNull(response.getBannerImgList())){
+                stringList.addAll(Arrays.asList(response.getBannerImgList()));
+            }
+            if(StringUtils.isNotBlank(response.getContent())){
+                // 娣诲姞 瀵屾枃鏈� 鍥剧墖
+                stringList.addAll(Constants.getImgsFromHtmlText(response.getContent()));
+
+            }
+            List<ZTSpaceInfoResponse> ztSpaceInfoResponseList = response.getSpaceList();
+            if(CollectionUtils.isNotEmpty(ztSpaceInfoResponseList)){
+                for (ZTSpaceInfoResponse ztSpaceInfoResponse:ztSpaceInfoResponseList) {
+                    if(StringUtils.isNotBlank(ztSpaceInfoResponse.getSpaceImg())){
+                        stringList.add(ztSpaceInfoResponse.getSpaceImg());
+                    }
+                    if(StringUtils.isNotBlank(ztSpaceInfoResponse.getSpaceContent())){
+                        //娣诲姞 瀵屾枃鏈� 鍥剧墖
+                        stringList.addAll(Constants.getImgsFromHtmlText(ztSpaceInfoResponse.getSpaceContent()));
+                    }
+                }
+            }
+            response.setImageurlList(stringList);
+        }
+        return response;
+    }
+
+    @Override
+    public ZTCaseInfoResponse getWholecaseInfo(String id,String userType,Long userId,String salesId){
+        //鏌ヨ 涓彴 TOKEN
+        ZTBaseInfoResponse ztBaseInfoResponse  = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,userId,userType);
+        ZTContentInfoRequest ztContentListRequest = new ZTContentInfoRequest();
+        ztContentListRequest.setToken(ztBaseInfoResponse.getToken());
+        ztContentListRequest.setUserType(ztBaseInfoResponse.getUserType());
+        ztContentListRequest.setId(id);
+        ZTCaseInfoResponse response = zbomZhongTaiService.getWholecaseInfo(ztContentListRequest);
+        if(Objects.nonNull(response)){
+            //鏌ヨ瀵艰喘淇℃伅 杩涜淇℃伅缁戝畾涓庤繑鍥�
+            if(StringUtils.isNotBlank(salesId)&&userType.equals(ZTConstants.CUSTOMER)){
+                Users users = usersMapper.selectById(salesId);
+                Member member = memberMapper.selectById(userId);
+                if(Objects.nonNull(users)&&Objects.nonNull(member)&&StringUtils.isNotBlank(member.getOpenid())){
+                    MemberServiceImpl.saveCustomerUser(zbomZhongTaiService,customerUserMapper,memberMapper,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())){
+                        users.setImgurlFull(prefix + users.getImgurl());
+                    }
+                    response.setUsers(users);
+                    memberMapper.updateById(member);
+                }
+                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());
+                }
+            }
+            List<String> stringList = new ArrayList<String>();
+            if (StringUtils.isNotBlank(response.getCoverImage())) {
+                stringList.add(response.getCoverImage());
+            }
+            if(Objects.nonNull(response.getLayoutUlr())){
+                stringList.add(response.getLayoutUlr());
+            }
+            APISpaceCaseVo[]  apiSpaceCaseVoList = response.getApiSpaceCaseVos();
+            if(Objects.nonNull(apiSpaceCaseVoList)){
+                for (APISpaceCaseVo apiSpaceCaseVo:apiSpaceCaseVoList) {
+                    if(StringUtils.isNotBlank(apiSpaceCaseVo.getCoverImage())){
+                        stringList.add(apiSpaceCaseVo.getCoverImage());
+                    }
+                    if(Objects.nonNull(apiSpaceCaseVo.getImgList())){
+                        stringList.addAll(Arrays.asList(apiSpaceCaseVo.getImgList()));
+                    }
+                }
+            }
+            response.setImageurlList(stringList);
+        }
+        return response;
+    }
+
+    @Override
+    public ZTProductNewsInfoResponse getProductNewsInfo(String id,String userType,Long userId,String salesId){
+        //鏌ヨ 涓彴 TOKEN
+        ZTBaseInfoResponse ztBaseInfoResponse  = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,userId,userType);
+        ZTContentInfoRequest ztContentListRequest = new ZTContentInfoRequest();
+        ztContentListRequest.setToken(ztBaseInfoResponse.getToken());
+        ztContentListRequest.setUserType(ztBaseInfoResponse.getUserType());
+        ztContentListRequest.setId(id);
+        ZTProductNewsInfoResponse response = zbomZhongTaiService.getProductNewsInfo(ztContentListRequest);
+        if(Objects.nonNull(response)){
+            //鏌ヨ瀵艰喘淇℃伅 杩涜淇℃伅缁戝畾涓庤繑鍥�
+            if(StringUtils.isNotBlank(salesId)&&userType.equals(ZTConstants.CUSTOMER)){
+                Users users = usersMapper.selectById(salesId);
+                Member member = memberMapper.selectById(userId);
+                if(Objects.nonNull(users)&&Objects.nonNull(member)&&StringUtils.isNotBlank(member.getOpenid())){
+                    MemberServiceImpl.saveCustomerUser(zbomZhongTaiService,customerUserMapper,memberMapper,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())){
+                        users.setImgurlFull(prefix + users.getImgurl());
+                    }
+                    response.setUsers(users);
+                    memberMapper.updateById(member);
+                }
+                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());
+                }
+            }
+            List<String> stringList = new ArrayList<String>();
+            if (StringUtils.isNotBlank(response.getCoverImage())) {
+                stringList.add(response.getCoverImage());
+            }
+            if(Objects.nonNull(response.getBannerImgList())){
+                stringList.addAll(Arrays.asList(response.getBannerImgList()));
+            }
+            if(StringUtils.isNotBlank(response.getContent())){
+                stringList.addAll(Constants.getImgsFromHtmlText(response.getContent()));
+
+            }
+            List<ZTSpaceInfoResponse> ztSpaceInfoResponseList = response.getSpaceList();
+            if(CollectionUtils.isNotEmpty(ztSpaceInfoResponseList)){
+                for (ZTSpaceInfoResponse ztSpaceInfoResponse:ztSpaceInfoResponseList) {
+                    if(StringUtils.isNotBlank(ztSpaceInfoResponse.getSpaceImg())){
+                        stringList.add(ztSpaceInfoResponse.getSpaceImg());
+                    }
+                    if(StringUtils.isNotBlank(ztSpaceInfoResponse.getSpaceContent())){
+                        //娣诲姞 瀵屾枃鏈� 鍥剧墖
+                        stringList.addAll(Constants.getImgsFromHtmlText(ztSpaceInfoResponse.getSpaceContent()));
+                    }
+                }
+            }
+            response.setImageurlList(stringList);
+        }
+        return response;
+    }
+
+    @Override
+    public ZTRealcaseInfoResponse getRealcaseInfo(String id,String userType,Long userId,String salesId){
+        //鏌ヨ 涓彴 TOKEN
+        ZTBaseInfoResponse ztBaseInfoResponse  = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,userId,userType);
+        ZTContentInfoRequest ztContentListRequest = new ZTContentInfoRequest();
+        ztContentListRequest.setToken(ztBaseInfoResponse.getToken());
+        ztContentListRequest.setUserType(ztBaseInfoResponse.getUserType());
+        ztContentListRequest.setId(id);
+        ZTRealcaseInfoResponse response = zbomZhongTaiService.getRealcaseInfo(ztContentListRequest);
+        if(Objects.nonNull(response)){
+            //鏌ヨ瀵艰喘淇℃伅 杩涜淇℃伅缁戝畾涓庤繑鍥�
+            if(StringUtils.isNotBlank(salesId)&&userType.equals(ZTConstants.CUSTOMER)){
+                Users users = usersMapper.selectById(salesId);
+                Member member = memberMapper.selectById(userId);
+                if(Objects.nonNull(users)&&Objects.nonNull(member)&&StringUtils.isNotBlank(member.getOpenid())){
+                    MemberServiceImpl.saveCustomerUser(zbomZhongTaiService,customerUserMapper,memberMapper,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())){
+                        users.setImgurlFull(prefix + users.getImgurl());
+                    }
+                    response.setUsers(users);
+                    memberMapper.updateById(member);
+                }
+                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());
+                }
+            }
+            List<String> stringList = new ArrayList<String>();
+            if (StringUtils.isNotBlank(response.getCoverImage())) {
+                stringList.add(response.getCoverImage());
+            }
+            if(Objects.nonNull(response.getContentImgList())){
+                stringList.addAll(Arrays.asList(response.getContentImgList()));
+            }
+            response.setImageurlList(stringList);
+        }
+        return response;
+    }
+
+
+
+    @Override
+    public ZTBasePageResponse<ZTCollectLikeInfoResponse> collectLikePage(ZTCollectLikeRequest ztCollectLikeRequest){
+        if(Objects.isNull(ztCollectLikeRequest)
+                || Objects.isNull(ztCollectLikeRequest.getPageNum())
+                || Objects.isNull(ztCollectLikeRequest.getPageSize())
+                || StringUtils.isBlank(ztCollectLikeRequest.getBusinessType())
+                || StringUtils.isBlank(ztCollectLikeRequest.getBusinessCategory())
+        ){
+            throw new BusinessException(ResponseStatus.BAD_REQUEST);
+        }
+        //鏌ヨ 涓彴
+        ZTBaseInfoResponse ztBaseInfoResponse = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,
+                Long.valueOf(ztCollectLikeRequest.getUserId()),ztCollectLikeRequest.getUserType());
+        ztCollectLikeRequest.setToken(ztBaseInfoResponse.getToken());
+        ZTBasePageResponse<ZTCollectLikeInfoResponse> response = zbomZhongTaiService.collectLikePage(ztCollectLikeRequest);
+        return response;
+    }
+
+    @Override
+    public void batchAddLike(ZTBatchAddListRequest ztBatchAddListRequest){
+        if(Objects.isNull(ztBatchAddListRequest)
+                || StringUtils.isBlank(ztBatchAddListRequest.getArticleIds())
+                || StringUtils.isBlank(ztBatchAddListRequest.getPlatId())
+                || StringUtils.isBlank(ztBatchAddListRequest.getPlatSource())
+        ){
+            throw new BusinessException(ResponseStatus.BAD_REQUEST);
+        }
+        //鏌ヨ 涓彴
+        ZTBaseInfoResponse ztBaseInfoResponse = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,
+                Long.valueOf(ztBatchAddListRequest.getUserId()),ztBatchAddListRequest.getUserType());
+        ztBatchAddListRequest.setToken(ztBaseInfoResponse.getToken());
+        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