From 40f16ff7071c793bc02cf3f8ca8c0aa60aa85e21 Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期五, 19 七月 2024 09:05:03 +0800 Subject: [PATCH] 提交 --- server/service/src/main/java/com/doumee/service/business/impl/GetZhongTaiDataServiceImpl.java | 320 ++++++++++++++++++++++++++++++++-------------------- 1 files changed, 196 insertions(+), 124 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 1362ac7..47b86ee 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,5 +1,6 @@ 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; @@ -7,15 +8,20 @@ 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.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.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.ArrayList; @@ -43,6 +49,9 @@ @Autowired private SystemDictDataBiz systemDictDataBiz; + @Autowired + private RedisTemplate<String, Object> redisTemplate; + @Override @@ -50,14 +59,6 @@ if(Objects.isNull(ztCatalogListRequest) || 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(),"鍒嗙被淇℃伅閿欒"); } return zbomZhongTaiService.getCatalogList(ztCatalogListRequest); } @@ -73,85 +74,15 @@ } - /** - * 鑾峰彇鐖跺瓙绾х粨鏋勬暟鎹垪琛� - * 蹇楄瑁呬慨 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()) -// || StringUtils.isBlank(ztContentListRequest.getTagCodes()) - ){ - throw new BusinessException(ResponseStatus.BAD_REQUEST); - } - //鏌ヨ 涓彴 - ZTBaseInfoResponse ztBaseInfoResponse = MemberServiceImpl.getZTToken(zbomZhongTaiService,memberMapper,usersMapper,systemDictDataBiz, - Long.valueOf(ztContentListRequest.getUserId()),ztContentListRequest.getUserType()); - ztContentListRequest.setToken(ztBaseInfoResponse.getToken()); - String catalogCode = ztContentListRequest.getCatalogCode(); - ZTBasePageResponse<ZTContentListResponse> response = zbomZhongTaiService.pageContentList(ztContentListRequest); - 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); - 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()); + param.setActionType(actionType); ZTBaseResponse ztBaseResponse = zbomZhongTaiService.collectDo(param); if(Objects.isNull(ztBaseResponse)){ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"涓彴鎺ュ彛鍝嶅簲澶辫触"); @@ -163,62 +94,203 @@ } @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(),"涓彴鎺ュ彛鍝嶅簲澶辫触"); + 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)){ + ztAreaTreeResponses = zbomZhongTaiService.getAreaTreeList(ztAreaListRequest); + redisTemplate.opsForValue().set(Constants.RedisKeys.ZBOM_AREA_REDIS_KEY,JSONArray.toJSONString(ztAreaTreeResponses)); }else{ - if(!ztBaseResponse.getSuccess()){ - throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"涓彴璇锋眰淇℃伅寮傚父锛�"+ztBaseResponse.getMsg()); - } + ztAreaTreeResponses = JSONArray.parseArray(data,ZTAreaTreeResponse.class); } + 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; + } + + + + @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 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()); - } + 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()); + ZTBasePageResponse<ZTProductInfoResponse> response = zbomZhongTaiService.pageProductList(ztContentListRequest); + return response; } @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<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){ + //鏌ヨ 涓彴 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); + return response; + } + + @Override + public ZTCaseInfoResponse getWholecaseInfo(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); + ZTCaseInfoResponse response = zbomZhongTaiService.getWholecaseInfo(ztContentListRequest); + return response; + } + + @Override + public ZTProductNewsInfoResponse getProductNewsInfo(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); + ZTProductNewsInfoResponse response = zbomZhongTaiService.getProductNewsInfo(ztContentListRequest); + return response; + } + + @Override + public ZTRealcaseInfoResponse getRealcaseInfo(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); + ZTRealcaseInfoResponse response = zbomZhongTaiService.getRealcaseInfo(ztContentListRequest); + return response; } } -- Gitblit v1.9.3