From 53e0cba6de254a1d6f19d0287da0b212f4a5ae90 Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期二, 16 七月 2024 17:22:05 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
server/service/src/main/java/com/doumee/service/business/impl/GetZhongTaiDataServiceImpl.java | 164 +++++++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 161 insertions(+), 3 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 f466c22..e081da9 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
@@ -3,19 +3,22 @@
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.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.dao.business.IamInterfaceLogMapper;
import com.doumee.dao.business.MemberMapper;
+import com.doumee.dao.business.UsersMapper;
+import com.doumee.dao.web.response.ZTBaseInfoResponse;
import com.doumee.service.business.GetZhongTaiDataService;
+import com.github.xiaoymin.knife4j.core.util.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
+import org.apache.xpath.operations.Bool;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
@@ -33,6 +36,9 @@
@Autowired
private MemberMapper memberMapper;
+
+ @Autowired
+ private UsersMapper usersMapper;
@Autowired
private SystemDictDataBiz systemDictDataBiz;
@@ -71,8 +77,160 @@
}
+ /**
+ * 鑾峰彇鐖跺瓙绾х粨鏋勬暟鎹垪琛�
+ * 蹇楄瑁呬慨 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())
+ || StringUtils.isBlank(ztContentListRequest.getQuery())
+ || StringUtils.isBlank(ztContentListRequest.getSortType())
+ ){
+ 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();
+ 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(),"鍒嗙被淇℃伅閿欒");
+ }
+ 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){
+ 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());
+ }
+ }
+ }
+
+ @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());
+ }
+ }
+ }
}
--
Gitblit v1.9.3