From 88511250ea29b08f66f40daaa4e1fccbc74dac8f Mon Sep 17 00:00:00 2001 From: lisy <linlangsur163@163.com> Date: 星期二, 08 八月 2023 19:29:14 +0800 Subject: [PATCH] app端口:积分商品兑换-添加现金功能模块 --- cloud-server-account/src/main/java/com/dsh/account/service/impl/UserIntegralChangesServiceImpl.java | 48 +++++++++++++++++++++++++++++++++++++----------- 1 files changed, 37 insertions(+), 11 deletions(-) diff --git a/cloud-server-account/src/main/java/com/dsh/account/service/impl/UserIntegralChangesServiceImpl.java b/cloud-server-account/src/main/java/com/dsh/account/service/impl/UserIntegralChangesServiceImpl.java index 68321ea..f735165 100644 --- a/cloud-server-account/src/main/java/com/dsh/account/service/impl/UserIntegralChangesServiceImpl.java +++ b/cloud-server-account/src/main/java/com/dsh/account/service/impl/UserIntegralChangesServiceImpl.java @@ -1,14 +1,18 @@ package com.dsh.account.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.dsh.account.entity.TAppUser; +import com.dsh.account.entity.UserIntegral; import com.dsh.account.entity.UserIntegralChanges; import com.dsh.account.feignclient.activity.MerChandiseClient; import com.dsh.account.mapper.TAppUserMapper; import com.dsh.account.mapper.UserIntegralChangesMapper; +import com.dsh.account.model.IntegralListQuery; import com.dsh.account.model.SaveUserIntegralChangesVo; import com.dsh.account.model.vo.userBenefitDetail.ExchangeDetailsResponse; +import com.dsh.account.model.vo.userBenefitDetail.ExchangeDetailsVo; import com.dsh.account.model.vo.userBenefitDetail.IntegralsData; import com.dsh.account.model.vo.userBenefitDetail.PointDetailsVo; import com.dsh.account.service.UserIntegralChangesService; @@ -122,22 +126,44 @@ @Override public List<ExchangeDetailsResponse> queryExchangeGoodsdetails(Integer userIdFormRedis, Integer useType, Integer goodType) { - List<ExchangeDetailsResponse> integralExchangeDetails = mcClient.getIntegralExchangeDetails(userIdFormRedis); - if (ToolUtil.isNotEmpty(useType)){ - integralExchangeDetails = integralExchangeDetails.stream() - .filter(response -> Objects.equals(response.getUseStatus(), useType)) - .collect(Collectors.toList()); + List<ExchangeDetailsResponse> detailsResponses = new ArrayList<>(); + ExchangeDetailsVo integralExchangeDetails = mcClient.getIntegralExchangeDetails(userIdFormRedis); + if (ToolUtil.isNotEmpty(integralExchangeDetails.getDetailsResponses())){ + if (ToolUtil.isNotEmpty(useType)){ + detailsResponses = integralExchangeDetails.getDetailsResponses().stream() + .filter(response -> Objects.equals(response.getUseStatus(), useType)) + .collect(Collectors.toList()); + } + if (ToolUtil.isNotEmpty(goodType)){ + detailsResponses = integralExchangeDetails.getDetailsResponses().stream() + .filter(response -> Objects.equals(response.getGoodType(), goodType)) + .collect(Collectors.toList()); + } } - if (ToolUtil.isNotEmpty(goodType)){ - integralExchangeDetails = integralExchangeDetails.stream() - .filter(response -> Objects.equals(response.getGoodType(), goodType)) - .collect(Collectors.toList()); - } - return integralExchangeDetails; + return detailsResponses; } @Override public PointDetailsVo queryRedemptionDetails(Integer detailsId) { return mcClient.getSpecificsOfGoods(detailsId); } + + @Override + public List<UserIntegral> listAll(Page<UserIntegral> userIntegralPage, IntegralListQuery integralListQuery) { + String sTime =null; + String eTime =null; + if(ToolUtil.isNotEmpty(integralListQuery.getTime())){ + sTime = integralListQuery.getTime().split(" - ")[0]+" 00:00:00"; + eTime = integralListQuery.getTime().split(" - ")[1]+" 23:59:59"; + } + List<UserIntegral> userIntegrals = this.baseMapper.listAll(userIntegralPage, integralListQuery, sTime, eTime); + for (UserIntegral userIntegral : userIntegrals) { + if(userIntegral.getCategory()==1){ + userIntegral.setIntegral(userIntegral.getNewIntegral()-userIntegral.getOldIntegral()); + }else { + userIntegral.setIntegral(userIntegral.getOldIntegral()-userIntegral.getNewIntegral()); + } + } + return userIntegrals; + } } -- Gitblit v1.7.1