From a75b18a4157ab486e0b51c438ac165ab3a08e3e0 Mon Sep 17 00:00:00 2001 From: k94314517 <8417338+k94314517@user.noreply.gitee.com> Date: 星期四, 25 七月 2024 18:10:00 +0800 Subject: [PATCH] 代码提交 --- server/service/src/main/java/com/doumee/biz/zbom/impl/ZbomZhongTaiServiceImpl.java | 540 ++++++++++++++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 491 insertions(+), 49 deletions(-) diff --git a/server/service/src/main/java/com/doumee/biz/zbom/impl/ZbomZhongTaiServiceImpl.java b/server/service/src/main/java/com/doumee/biz/zbom/impl/ZbomZhongTaiServiceImpl.java index 1a1c786..dc18be7 100644 --- a/server/service/src/main/java/com/doumee/biz/zbom/impl/ZbomZhongTaiServiceImpl.java +++ b/server/service/src/main/java/com/doumee/biz/zbom/impl/ZbomZhongTaiServiceImpl.java @@ -16,9 +16,11 @@ import com.doumee.dao.business.MemberMapper; import com.doumee.dao.business.model.CrmInterfaceLog; import com.doumee.dao.business.model.InterfaceLog; +import com.doumee.dao.web.response.ZSZXCatalogResponse; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import java.util.Date; @@ -36,6 +38,9 @@ public class ZbomZhongTaiServiceImpl implements ZbomZhongTaiService { @Autowired private InterfaceLogMapper interfaceLogMapper; + @Autowired + private RedisTemplate<String, Object> redisTemplate; + /** * 鑾峰彇鐢ㄦ埛鐧婚檰token * @param param @@ -48,29 +53,55 @@ ZTConstants.IntegerName.USER_GET_TOKEN_NAME, param.getToken(), param.getUserType(), - JSONObject.toJSONString(param )); + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTUserGetTokenResponse>>(){}); if(result!=null){ return result.getData(); } return null; } /** + * 鑾峰彇B绔敤鎴风櫥闄唗oken + * @param mobile + * @return + */ + @Override + public ZTSysuserGetTokenResponse getSysuserToken(String mobile){ + ZTBaseResponse<ZTSysuserGetTokenResponse> result = sendSysHttpRequest( + ZTConstants.IntegerUrl.USER_MOBILE_FASTLOGIN_URL+"?mobile="+mobile, + ZTConstants.IntegerName.USER_MOBILE_FASTLOGIN_NAME, + null, + null, + "", + new TypeReference<ZTBaseResponse<ZTSysuserGetTokenResponse>>(){}); + if(result!=null){ + return result.getData(); + } + return null; + } + /** + * 鑾峰彇鐢ㄦ埛鐧婚檰token + * @return + */ + + /** * 鐢ㄦ埛淇℃伅鍚屾 * @param param * @return */ @Override - public ZTUserGetTokenResponse userUpdateInfo(ZTUserInfoUpdateRequest param){ + public ZTBaseResponse userUpdateInfo(ZTUserInfoUpdateRequest param){ ZTBaseResponse<ZTUserGetTokenResponse> result = sendHttpRequest( ZTConstants.IntegerUrl.USER_UPDATE_URL, ZTConstants.IntegerName.USER_UPDATE_NAME, - param.getToken(), - param.getUserType(), - JSONObject.toJSONString(param )); - if(result!=null){ - return result.getData(); - } - return null; + null, + null, + JSONObject.toJSONString(param), + new TypeReference<ZTBaseResponse<ZTUserGetTokenResponse>>(){}); +// if(result!=null){ +// return result.getData(); +// } + return result; } /** * 娉ㄩ攢鐢ㄦ埛 @@ -84,7 +115,8 @@ ZTConstants.IntegerName.USER_LOGOUT_NAME, param.getToken(), param.getUserType(), - JSONObject.toJSONString(param )); + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<Object>>(){}); if(result!=null ){ return true; } @@ -98,12 +130,33 @@ */ @Override public List<ZTCatalogInfoResponse> getCatalogList(ZTCatalogListRequest param){ - ZTBaseResponse<List<ZTCatalogInfoResponse>> result = sendHttpRequest( + + ZTBaseResponse<List<ZTCatalogInfoResponse>> result = sendHttpRequest( ZTConstants.IntegerUrl.CATALOG_LIST_URL, ZTConstants.IntegerName.CATALOG_LIST_NAME, param.getToken(), param.getUserType(), - JSONObject.toJSONString(param )); + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<List<ZTCatalogInfoResponse>>>(){}); + if(result!=null){ + return result.getData(); + } + return null; + } + /** + * 鑾峰彇鍒嗙被鍜屽垎绫讳笅鐨勬爣绛� + * @param param + * @return + */ + @Override + public List<ZTTagInfoResponse> getTagList(ZTCatalogListRequest param){ + ZTBaseResponse<List<ZTTagInfoResponse>> result = sendHttpRequest( + ZTConstants.IntegerUrl.TAG_LIST_URL, + ZTConstants.IntegerName.TAG_LIST_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<List<ZTTagInfoResponse>>>(){}); if(result!=null){ return result.getData(); } @@ -122,11 +175,205 @@ ZTConstants.IntegerName.CONTENT_LIST_NAME, param.getToken(), param.getUserType(), - JSONObject.toJSONString(param )); + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTBasePageResponse<ZTContentListResponse>>>(){}); + if(result!=null){ + return result.getData(); +// TypeReference<ZTBasePageResponse<ZTContentListResponse>> typeReference = new TypeReference<ZTBasePageResponse<ZTContentListResponse>>(){}; +// ZTBasePageResponse<ZTContentListResponse> ztBasePageResponse = JSONObject.parseObject(result.getData(), typeReference.getType()); +// return ztBasePageResponse; + } + return null; + } + /** + * 鑾峰彇瑙嗛鍒楄〃鍒嗛〉 + * @param param + * @return + */ + @Override + public ZTBasePageResponse<ZTZbDecoInfoResponse> pageZbDecoList(ZTContentListRequest param){ + ZTBaseResponse<ZTBasePageResponse<ZTZbDecoInfoResponse>> result = sendHttpRequest( + ZTConstants.IntegerUrl.ZBDECO_PAGE_LIST_URL, + ZTConstants.IntegerName.ZBDECO_PAGE_LIST_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTBasePageResponse<ZTZbDecoInfoResponse>>>(){}); if(result!=null){ return result.getData(); } return null; + } + /** + * 鑾峰彇瑙嗛鍒楄〃鍒嗛〉 + * @param param + * @return + */ + @Override + public ZTBasePageResponse<ZTVideoInfoResponse> pageVideoList(ZTContentListRequest param){ + ZTBaseResponse<ZTBasePageResponse<ZTVideoInfoResponse>> result = sendHttpRequest( + ZTConstants.IntegerUrl.VIDEO_PAGE_LIST_URL, + ZTConstants.IntegerName.VIDEO_PAGE_LIST_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTBasePageResponse<ZTVideoInfoResponse>>>(){}); + if(result!=null){ + return result.getData(); + } + return null; + } + /** + * 鑾峰彇浜у搧璧勮鍒楄〃鍒嗛〉 + * @param param + * @return + */ + @Override + public ZTBasePageResponse<ZTProductNewsInfoResponse> pageProductNewsList(ZTContentListRequest param){ + ZTBaseResponse<ZTBasePageResponse<ZTProductNewsInfoResponse>> result = sendHttpRequest( + ZTConstants.IntegerUrl.PRODUCT_NEWS_PAGE_LIST_URL, + ZTConstants.IntegerName.PRODUCT_NEWS_PAGE_LIST_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTBasePageResponse<ZTProductNewsInfoResponse>>>(){}); + if(result!=null){ + return result.getData(); + } + return null; + } + /** + * 鑾峰彇浜у搧鍒楄〃鍒嗛〉 + * @param param + * @return + */ + @Override + public ZTBasePageResponse<ZTProductInfoResponse> pageProductList(ZTContentListRequest param){ + ZTBaseResponse<ZTBasePageResponse<ZTProductInfoResponse>> result = sendHttpRequest( + ZTConstants.IntegerUrl.PRODUCT_PAGE_LIST_URL, + ZTConstants.IntegerName.PRODUCT_PAGE_LIST_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTBasePageResponse<ZTProductInfoResponse>>>(){}); + if(result!=null){ + return result.getData(); + } + return null; + } + /** + * 鑾峰彇鍏ㄥ眿妗堜緥鍒楄〃鍒嗛〉 + * @param param + * @return + */ + @Override + public ZTBasePageResponse<ZTCaseInfoResponse> pageWholecaseList(ZTContentListRequest param){ + ZTBaseResponse<ZTBasePageResponse<ZTCaseInfoResponse>> result = sendHttpRequest( + ZTConstants.IntegerUrl.WHOLECASE_PAGE_LIST_URL, + ZTConstants.IntegerName.WHOLECASE_PAGE_LIST_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTBasePageResponse<ZTCaseInfoResponse>>>(){}); + if(result!=null){ + return result.getData(); + } + return null; + } + /** + * 鑾峰彇瀹炴櫙妗堜緥鍒楄〃鍒嗛〉 + * @param param + * @return + */ + @Override + public ZTBasePageResponse<ZTRealcaseInfoResponse> pageRealcaseList(ZTContentListRequest param){ + ZTBaseResponse<ZTBasePageResponse<ZTRealcaseInfoResponse>> result = sendHttpRequest( + ZTConstants.IntegerUrl.REALCASE_PAGE_LIST_URL, + ZTConstants.IntegerName.REALCASE_PAGE_LIST_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTBasePageResponse<ZTRealcaseInfoResponse>>>(){}); + if(result!=null){ + return result.getData(); + } + return null; + } + /** + * 鑾峰彇浜у搧璇︽儏 + * @param param + * @return + */ + @Override + public ZTProductInfoResponse getProductInfo(ZTContentInfoRequest param){ + ZTBaseResponse<ZTProductInfoResponse> result = sendHttpRequest( + ZTConstants.IntegerUrl.PRODUCT_INFO_URL, + ZTConstants.IntegerName.PRODUCT_INFO_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTProductInfoResponse>>(){}); + if(result!=null){ + return result.getData(); + } + return null; + } + /** + * 鑾峰彇浜у搧璧勮璇︽儏 + * @param param + * @return + */ + @Override + public ZTProductNewsInfoResponse getProductNewsInfo(ZTContentInfoRequest param){ + ZTBaseResponse<ZTProductNewsInfoResponse> result = sendHttpRequest( + ZTConstants.IntegerUrl.PRODUCT_NEWS_INFO_URL, + ZTConstants.IntegerName.PRODUCT_NEWS_INFO_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTProductNewsInfoResponse>>(){}); + if(result!=null){ + return result.getData(); + } + return null; + } + /** + * 鑾峰彇瀹炴櫙璧勮璇︽儏 + * @param param + * @return + */ + @Override + public ZTRealcaseInfoResponse getRealcaseInfo(ZTContentInfoRequest param){ + ZTBaseResponse<ZTRealcaseInfoResponse> result = sendHttpRequest( + ZTConstants.IntegerUrl.REALCASE_INFO_URL, + ZTConstants.IntegerName.REALCASE_INFO_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTRealcaseInfoResponse>>(){}); + if(result!=null){ + return result.getData(); + } + return null; + } + /** + * 鑾峰彇鍏ㄥ眿璧勮璇︽儏 + * @param param + * @return + */ + @Override + public ZTCaseInfoResponse getWholecaseInfo(ZTContentInfoRequest param){ + ZTBaseResponse<ZTCaseInfoResponse> result = sendHttpRequest( + ZTConstants.IntegerUrl.WHOLECASE_INFO_URL, + ZTConstants.IntegerName.WHOLECASE_INFO_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTCaseInfoResponse>>(){}); + if(result!=null){ + return result.getData(); + } + return null; } /** * 鑾峰彇鍐呭璇︽儏 @@ -136,11 +383,12 @@ @Override public ZTContentInfoResponse getContentInfo(ZTContentInfoRequest param){ ZTBaseResponse<ZTContentInfoResponse> result = sendHttpRequest( - ZTConstants.IntegerUrl.CONTENT_INFO_URL+ param.getArticleId(), + ZTConstants.IntegerUrl.CONTENT_INFO_URL+ param.getId(), ZTConstants.IntegerName.CONTENT_INFO_NAME, param.getToken(), param.getUserType(), - JSONObject.toJSONString(param )); + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTContentInfoResponse>>(){}); if(result!=null){ return result.getData(); } @@ -152,17 +400,16 @@ * @return */ @Override - public boolean collectDo(ZTActionDoRequest param){ + public ZTBaseResponse collectDo(ZTActionDoRequest param){ ZTBaseResponse result = sendHttpRequest( ZTConstants.IntegerUrl.COLLECT_DO_URL, ZTConstants.IntegerName.COLLECT_DO_NAME, param.getToken(), param.getUserType(), - JSONObject.toJSONString(param )); - if(result!=null ){ - return true; - } - return false; + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<Object>>(){}); + + return result; } /** * 鍐呭鍠滄 @@ -170,17 +417,16 @@ * @return */ @Override - public boolean likeDo(ZTActionBatchDoRequest param){ + public ZTBaseResponse likeDo(ZTActionBatchDoRequest param){ ZTBaseResponse result = sendHttpRequest( ZTConstants.IntegerUrl.LIKE_DO_URL, ZTConstants.IntegerName.LIKE_DO_NAME, param.getToken(), param.getUserType(), - JSONObject.toJSONString(param )); - if(result!=null ){ - return true; - } - return false; + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<Object>>(){}); + + return result; } /** * 鍐呭鍒嗕韩 @@ -188,17 +434,15 @@ * @return */ @Override - public boolean shareDo(ZTActionDoRequest param){ + public ZTBaseResponse shareDo(ZTActionDoRequest param){ ZTBaseResponse result = sendHttpRequest( ZTConstants.IntegerUrl.SHARE_DO_URL, ZTConstants.IntegerName.SHARE_DO_NAME, param.getToken(), param.getUserType(), - JSONObject.toJSONString(param )); - if(result!=null ){ - return true; - } - return false; + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<Object>>(){}); + return result; } /** * 鍐呭娴忚 @@ -206,13 +450,30 @@ * @return */ @Override - public boolean viewDo(ZTActionDoRequest param){ + public ZTBaseResponse viewDo(ZTActionDoRequest param){ ZTBaseResponse result = sendHttpRequest( ZTConstants.IntegerUrl.VIEW_DO_URL, ZTConstants.IntegerName.VIEW_DO_NAME, param.getToken(), param.getUserType(), - JSONObject.toJSONString(param )); + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<Object>>(){}); + return result; + } + /** + * 鐢ㄦ埛缁戝畾瀹㈡埛鍠滄娓呭崟锛屽彲缁戝畾澶氫釜鍐呭 + * @param param + * @return + */ + @Override + public boolean bindCustomerFavorites(ZTBindCusFavoriteDoRequest param){ + ZTBaseResponse result = sendHttpRequest( + ZTConstants.IntegerUrl.BIND_CUSTOMER_FAVORITES_URL, + ZTConstants.IntegerName.BIND_CUSTOMER_FAVORITES_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<Object>>(){}); if(result!=null ){ return true; } @@ -224,13 +485,52 @@ * @return */ @Override - public ZTBasePageResponse<ZTContentListResponse> pageCollectList(ZTContentListRequest param){ - ZTBaseResponse< ZTBasePageResponse<ZTContentListResponse>> result = sendHttpRequest( + public ZTBasePageResponse<ZTCollectInfoResponse> pageCollectList(ZTContentListRequest param){ + ZTBaseResponse< ZTBasePageResponse<ZTCollectInfoResponse>> result = sendHttpRequest( ZTConstants.IntegerUrl.COLLECT_LIST_URL, ZTConstants.IntegerName.COLLECT_LIST_NAME, param.getToken(), param.getUserType(), - JSONObject.toJSONString(param )); + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTBasePageResponse<ZTCollectInfoResponse>>>(){}); + if(result!=null){ + return result.getData(); + } + return null; + } + /** + * 鑾峰彇鎴戠殑鏀惰棌鍒楄〃鍒嗛〉 + * @param param + * @return + */ + @Override + public ZTBasePageResponse<ZTBehaviorInfoResponse> pageBehavoirList(ZTContentListRequest param){ + ZTBaseResponse< ZTBasePageResponse<ZTBehaviorInfoResponse>> result = sendHttpRequest( + ZTConstants.IntegerUrl.BEHAVIOR_LIST_URL, + ZTConstants.IntegerName.BEHAVIOR_LIST_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTBasePageResponse<ZTBehaviorInfoResponse>>>(){}); + if(result!=null){ + return result.getData(); + } + return null; + } + /** + * 鑾峰彇瀹㈡埛鍠滄 + * @param param + * @return + */ + @Override + public ZTBasePageResponse<ZTCusFavoritesInfoResponse> pageCusFavoriteList(ZTContentListRequest param){ + ZTBaseResponse< ZTBasePageResponse<ZTCusFavoritesInfoResponse>> result = sendHttpRequest( + ZTConstants.IntegerUrl.CUSTOMER_FAVORITES_LIST_URL, + ZTConstants.IntegerName.CUSTOMER_FAVORITES_LIST_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTBasePageResponse<ZTCusFavoritesInfoResponse>>>(){}); if(result!=null){ return result.getData(); } @@ -249,13 +549,53 @@ ZTConstants.IntegerName.LIKE_LIST_NAME, param.getToken(), param.getUserType(), - JSONObject.toJSONString(param )); + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTBasePageResponse<ZTContentListResponse>>>(){}); if(result!=null){ return result.getData(); } return null; } + + + /** + * 杞挱鍥惧垪琛� + * @param param + * @return + */ + @Override + public List<ZTCusCarouselImageResponse> carouselImageList(ZTContentListRequest param){ + ZTBaseResponse<List<ZTCusCarouselImageResponse>> result = sendHttpRequest( + ZTConstants.IntegerUrl.CUSTOMER_CAROUSEL_IMAGE_URL, + ZTConstants.IntegerName.CUSTOMER_CAROUSEL_IMAGE_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<List<ZTCusCarouselImageResponse>>>(){}); + if(result!=null){ + return result.getData(); + } + return null; + } + + + @Override + public ZTCusCarouselImageResponse carouselImageDetail(ZTDataDetailRequest param){ + ZTBaseResponse<ZTCusCarouselImageResponse> result = sendHttpRequest( + ZTConstants.IntegerUrl.CUSTOMER_CAROUSEL_IMAGE_DETAIL_URL, + ZTConstants.IntegerName.CUSTOMER_CAROUSEL_IMAGE_DETAIL_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTCusCarouselImageResponse>>(){}); + if(result!=null){ + return result.getData(); + } + return null; + } + + /** * 鑾峰彇鑾峰彇鐪佸競鍖洪泦鍚� * @param param @@ -271,29 +611,55 @@ ZTConstants.IntegerName.AREA_LIST_NAME, param.getToken(), param.getUserType(), - JSONObject.toJSONString(param )); + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<List<ZTAreaInfoResponse>>>(){}); + if(result!=null){ + return result.getData(); + } + return null; + } + /** + * 鑾峰彇鑾峰彇鐪佸競鍖洪泦鍚� + * @param param + * @return + */ + @Override + public List<ZTAreaTreeResponse> getAreaTreeList(ZTAreaListRequest param){ + if(StringUtils.isBlank(param.getPid())){ + param.setPid(ZTConstants.DEFAULT_PID);//榛樿鍙栧叏閮ㄧ渷浠� + } + ZTBaseResponse<List<ZTAreaTreeResponse>> result = sendHttpRequest( + ZTConstants.IntegerUrl.AREA_TREE_URL, + ZTConstants.IntegerName.AREA_TREE_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<List<ZTAreaTreeResponse>>>(){}); if(result!=null){ return result.getData(); } return null; } - - public <T> ZTBaseResponse<T> sendHttpRequest(String url,String name,String token,String userType,String param){ + public <T> ZTBaseResponse<T> sendHttpRequest(String url,String name,String token,String userType,String param,TypeReference<ZTBaseResponse<T>> typeReference){ log.info("銆�"+name+"銆�================寮�濮�===="+ JSONObject.toJSONString(param)); String res = null; int success = 0; try { - Map<String,String> headers = new HashMap<>(); - headers.put(ZTConstants.HEADER_TOKEN,token); + if(StringUtils.equals(userType,ZTConstants.CUSTOMER)){ + //濡傛灉鏄疌绔鎴� + headers.put(ZTConstants.HEADER_TOKEN,token); + }else{ + //濡傛灉鏄疊绔敤鎴� + headers.put(ZTConstants.HEADER_SYSUSER_TOKEN,token); + } headers.put(ZTConstants.HEADER_USERTYPE,userType); - res = HttpsUtil.postJsonWithHeaders(url,param,headers); - TypeReference typeReference = - new TypeReference<ZTBaseResponse<T>>(){}; + String index = (String) redisTemplate.opsForValue().get(Constants.RedisKeys.ZBOM_ZHONGTAI_API_URL); + res = HttpsUtil.postJsonWithHeaders(index+url,param,headers); ZTBaseResponse<T> result = JSONObject.parseObject(res, typeReference.getType()); logResult(result,name); - if(StringUtils.equals(result.getCode(),ZTConstants.CODE_SUCCESS)){ + if(Constants.equalsInteger(result.getCode(),ZTConstants.CODE_SUCCESS)){ return result; }else{ success =1; @@ -306,6 +672,40 @@ } return null; } + + public <T> ZTBaseResponse<T> sendSysHttpRequest(String url,String name,String token,String userType,String param,TypeReference<ZTBaseResponse<T>> typeReference){ + log.info("銆�"+name+"銆�================寮�濮�===="+ JSONObject.toJSONString(param)); + String res = null; + int success = 0; + try { + Map<String,String> headers = new HashMap<>(); + if(StringUtils.equals(userType,ZTConstants.CUSTOMER)){ + //濡傛灉鏄疌绔鎴� + headers.put(ZTConstants.HEADER_TOKEN,token); + }else{ + //濡傛灉鏄疊绔敤鎴� + headers.put(ZTConstants.HEADER_SYSUSER_TOKEN,token); + } + headers.put(ZTConstants.HEADER_USERTYPE,userType); + String index = (String) redisTemplate.opsForValue().get(Constants.RedisKeys.ZBOM_ZHONGTAI_SYS_API_URL); + res = HttpsUtil.postJsonWithHeaders(index+url,param,headers); + ZTBaseResponse<T> result = JSONObject.parseObject(res, typeReference.getType()); + logResult(result,name); + if(Constants.equalsInteger(result.getCode(),ZTConstants.CODE_SUCCESS)){ + return result; + }else{ + success =1; + } + }catch (Exception e){ + success = 1; + log.error("銆�"+name+"銆�================澶辫触===="+ JSONObject.toJSONString(param)); + }finally { + saveInterfaceLog(url,name,param,success,res); + } + return null; + } + + public void saveInterfaceLog(String url,String name,String param,Integer success,String respone){ if(interfaceLogMapper ==null){ return; @@ -324,10 +724,52 @@ interfaceLogMapper.insert(log); } private static void logResult(ZTBaseResponse res,String name) { - if(StringUtils.equals(res.getCode(), ZTConstants.CODE_SUCCESS)){ + if(Constants.equalsInteger(res.getCode(),ZTConstants.CODE_SUCCESS)){ log.info("銆愪腑鍙版帴鍙o細"+name+"銆�================鎴愬姛====\n"+res); }else{ log.error("銆愪腑鍙版帴鍙o細"+name+"銆�================澶辫触====锛歕n"+ res); } } + + + /** + * 鑾峰彇鎴戠殑鍠滄/鏀惰棌鍒楄〃 + * @param param + * @return + */ + @Override + public ZTBasePageResponse<ZTCollectLikeInfoResponse> collectLikePage(ZTCollectLikeRequest param){ + ZTBaseResponse<ZTBasePageResponse<ZTCollectLikeInfoResponse>> result = sendHttpRequest( + ZTConstants.IntegerUrl.FAVORITES_PAGE_URL, + ZTConstants.IntegerName.FAVORITES_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<ZTBasePageResponse<ZTCollectLikeInfoResponse>>>(){}); + if(result!=null){ + return result.getData(); + } + return null; + } + + /** + * 鑾峰彇鍒嗙被鍜屽垎绫讳笅鐨勬爣绛� + * @param param + * @return + */ + @Override + public ZTBaseResponse batchAddLike(ZTBatchAddListRequest param){ + ZTBaseResponse result = sendHttpRequest( + ZTConstants.IntegerUrl.BATCH_ADD_LIKE_URL, + ZTConstants.IntegerName.BATCH_ADD_LIKE_NAME, + param.getToken(), + param.getUserType(), + JSONObject.toJSONString(param ), + new TypeReference<ZTBaseResponse<Object>>(){}); + if(result!=null){ + return result; + } + return null; + } + } -- Gitblit v1.9.3