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 |  543 ++++++++++++++++++++++++++++++++++++++++++++++--------
 1 files changed, 461 insertions(+), 82 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 b834ec6..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
@@ -1,26 +1,34 @@
 package com.doumee.service.business.impl;
 
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.doumee.biz.system.SystemDictDataBiz;
 import com.doumee.biz.zbom.ZbomZhongTaiService;
-import com.doumee.biz.zbom.model.zhongtai.ZTCatalogListRequest;
-import com.doumee.biz.zbom.model.zhongtai.ZTConstants;
-import com.doumee.biz.zbom.model.zhongtai.ZTContentInfoRequest;
-import com.doumee.biz.zbom.model.zhongtai.ZTContentListRequest;
+import com.doumee.biz.zbom.model.zhongtai.*;
 import com.doumee.biz.zbom.model.zhongtai.response.*;
 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;
+import com.google.gson.JsonArray;
 import org.apache.commons.lang3.StringUtils;
+import org.apache.xpath.operations.Bool;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
-import java.util.List;
-import java.util.Objects;
+import java.util.*;
 
 /**
  * Created by IntelliJ IDEA.
@@ -43,7 +51,35 @@
     @Autowired
     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){
@@ -51,12 +87,10 @@
         || 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(),"鍒嗙被淇℃伅閿欒");
-        }
+        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);
     }
 
@@ -67,101 +101,446 @@
                 || 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(),"鍒嗙被淇℃伅閿欒");
-        }
+        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);
-                }
+    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());
+        param.setActionType(actionType);
+        zbomZhongTaiService.collectDo(param);
+    }
+
+    @Override
+    public ZTBasePageResponse<ZTCusFavoritesInfoResponse> getZhongTaiCusFavorite(ZTContentListRequest ztContentListRequest){
+        ZTBaseInfoResponse ztBaseInfoResponse  =  MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,Long.valueOf(ztContentListRequest.getUserId()),ztContentListRequest.getUserType());
+        ztContentListRequest.setOpenId(ztBaseInfoResponse.getOpenId());
+        ztContentListRequest.setToken(ztBaseInfoResponse.getToken());
+        ZTBasePageResponse ztAreaTreeResponses = zbomZhongTaiService.pageCusFavoriteList(ztContentListRequest);
+        return ztAreaTreeResponses;
+    }
+
+    @Override
+    @Async
+    public void userLogout(ZTBaseRequst ztBaseRequst){
+        zbomZhongTaiService.userLogout(ztBaseRequst);
+    }
+
+    @Override
+    public List<ZTAreaTreeResponse> getZhongTaiAreaTree(ZTAreaListRequest ztAreaListRequest){
+        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);
+            if(CollectionUtils.isNotEmpty(ztAreaTreeResponses)){
+                redisTemplate.opsForValue().set(Constants.RedisKeys.ZBOM_AREA_REDIS_KEY,JSONArray.toJSONString(ztAreaTreeResponses));
             }
+        }else{
+            ztAreaTreeResponses = JSONArray.parseArray(data,ZTAreaTreeResponse.class);
         }
-        return ztCatalogInfoResponseList;
+        return ztAreaTreeResponses;
+    }
+
+    @Override
+    public List<ZTCusCarouselImageResponse> getZhongTaiCarouselImage(ZTContentListRequest ztContentListRequest){
+        ZTBaseInfoResponse ztBaseInfoResponse  =  MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,Long.valueOf(ztContentListRequest.getUserId()),ztContentListRequest.getUserType());
+        ztContentListRequest.setOpenId(ztBaseInfoResponse.getOpenId());
+        ztContentListRequest.setToken(ztBaseInfoResponse.getToken());
+        List<ZTCusCarouselImageResponse> ztCusCarouselImageResponseList = zbomZhongTaiService.carouselImageList(ztContentListRequest);
+        return ztCusCarouselImageResponseList;
+    }
+
+    @Override
+    public ZTCusCarouselImageResponse getZhongTaiCarouselImageDetail(ZTDataDetailRequest ztDataDetailRequest){
+        ZTBaseInfoResponse ztBaseInfoResponse  =  MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,Long.valueOf(ztDataDetailRequest.getUserId()),ztDataDetailRequest.getUserType());
+        ztDataDetailRequest.setOpenId(ztBaseInfoResponse.getOpenId());
+        ztDataDetailRequest.setToken(ztBaseInfoResponse.getToken());
+        ZTCusCarouselImageResponse ztCusCarouselImageResponse = zbomZhongTaiService.carouselImageDetail(ztDataDetailRequest);
+        return ztCusCarouselImageResponse;
     }
 
 
-    /**
-     * 鍐呭 鍒嗛〉鏁版嵁
-     * @param ztContentListRequest
-     * @return
-     */
+
     @Override
-    public ZTBasePageResponse<ZTContentListResponse> pageContentList(ZTContentListRequest ztContentListRequest){
+    public ZTBasePageResponse<ZTProductNewsInfoResponse> getZhongTaiProductNewsPage(ZTContentListRequest ztContentListRequest){
         if(Objects.isNull(ztContentListRequest)
-            || Objects.isNull(ztContentListRequest.getPageNum())
-            || Objects.isNull(ztContentListRequest.getPageSize())
-            || StringUtils.isBlank(ztContentListRequest.getCatalogCode())
-            || StringUtils.isBlank(ztContentListRequest.getTagCodes())
-            || StringUtils.isBlank(ztContentListRequest.getQuery())
-            || StringUtils.isBlank(ztContentListRequest.getSortType())
+                || Objects.isNull(ztContentListRequest.getPageNum())
+                || Objects.isNull(ztContentListRequest.getPageSize())
         ){
             throw new BusinessException(ResponseStatus.BAD_REQUEST);
         }
         //鏌ヨ 涓彴
-        String token = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,ztContentListRequest.getUserId(),ztContentListRequest.getUserType());
-        ztContentListRequest.setToken(token);
-        String catalogCode = ztContentListRequest.getCatalogCode();
-        if(catalogCode.equals(ZTConstants.CatalogCode.ZHISHUO_ZHUANGXIU)
-                ||catalogCode.equals(ZTConstants.CatalogCode.CHANPING)
-                ||catalogCode.equals(ZTConstants.CatalogCode.ZIXUN)
-                ||catalogCode.equals(ZTConstants.CatalogCode.QW_CASE)){
-            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鍒嗙被淇℃伅閿欒");
+        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);
         }
-        ZTBasePageResponse<ZTContentListResponse> response = zbomZhongTaiService.pageContentList(ztContentListRequest);
+        //鏌ヨ 涓彴
+        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 ZTContentInfoResponse getContentInfo(String id,String userType,Long userId){
-        //鏌ヨ 涓彴 TOKEN
-        String token = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz,userId.toString(),userType);
-        ZTContentInfoRequest ztContentListRequest = new ZTContentInfoRequest();
-        ztContentListRequest.setToken(token);
-        ztContentListRequest.setUserType(userType);
-        ztContentListRequest.setId(id);
-        ZTContentInfoResponse response = zbomZhongTaiService.getContentInfo(ztContentListRequest);
+    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