From 4dc531fc2dcd6517fffa2e9760225f5705537258 Mon Sep 17 00:00:00 2001 From: k94314517 <8417338+k94314517@user.noreply.gitee.com> Date: 星期五, 19 七月 2024 20:11:27 +0800 Subject: [PATCH] 代码提交 --- server/service/src/main/java/com/doumee/service/business/impl/GetZhongTaiDataServiceImpl.java | 58 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 56 insertions(+), 2 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 47b86ee..31182ba 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 @@ -13,6 +13,7 @@ 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.ZSZXCatalogResponse; import com.doumee.dao.web.response.ZTBaseInfoResponse; import com.doumee.service.business.GetZhongTaiDataService; import com.github.xiaoymin.knife4j.core.util.CollectionUtils; @@ -52,7 +53,29 @@ @Autowired private RedisTemplate<String, Object> redisTemplate; - + @Override + public ZSZXCatalogResponse getZSZXCatalogs(Long userId){ + ZSZXCatalogResponse response = new ZSZXCatalogResponse(); + ZTCatalogListRequest param = new ZTCatalogListRequest(); + param.setUserId(userId.toString()); + param.setUserType(ZTConstants.CUSTOMER); + 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,6 +83,10 @@ || StringUtils.isBlank(ztCatalogListRequest.getCatalogCode())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } + 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); } @@ -70,6 +97,9 @@ || 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); } @@ -116,8 +146,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); } @@ -293,4 +328,23 @@ 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; + } } -- Gitblit v1.9.3