From 70477314b93450a4f063c8183eb3e21936264452 Mon Sep 17 00:00:00 2001 From: zhibing.pu <393733352@qq.com> Date: 星期一, 12 八月 2024 20:16:48 +0800 Subject: [PATCH] Merge branch 'master' of http://120.76.84.145:10101/gitblit/r/java/mx_charging_pile --- ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TOrderEvaluateServiceImpl.java | 46 ++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 46 insertions(+), 0 deletions(-) diff --git a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TOrderEvaluateServiceImpl.java b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TOrderEvaluateServiceImpl.java index 1c27a8a..e5735a1 100644 --- a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TOrderEvaluateServiceImpl.java +++ b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TOrderEvaluateServiceImpl.java @@ -3,6 +3,10 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.account.api.feignClient.AppUserCarClient; +import com.ruoyi.account.api.feignClient.AppUserClient; +import com.ruoyi.account.api.model.TAppUser; +import com.ruoyi.account.api.model.TAppUserCar; import com.ruoyi.account.api.feignClient.AppUserClient; import com.ruoyi.account.api.model.TAppUser; import com.ruoyi.chargingPile.api.feignClient.SiteClient; @@ -14,6 +18,7 @@ import com.ruoyi.order.api.model.TOrderEvaluate; import com.ruoyi.order.api.model.TOrderEvaluateTag; import com.ruoyi.order.api.query.TOrderEvaluateQuery; +import com.ruoyi.order.api.vo.SiteDetailEvaluateVO; import com.ruoyi.order.api.vo.TOrderEvaluateVO; import com.ruoyi.order.dto.GetOrderEvaluatePageList; import com.ruoyi.order.dto.GetOrderEvaluatePageListDTO; @@ -28,11 +33,13 @@ import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; +import java.math.BigDecimal; import javax.annotation.Resource; import java.util.Arrays; import java.util.Comparator; import java.util.List; import java.util.Map; +import java.util.Objects; import java.util.stream.Collectors; /** @@ -49,6 +56,11 @@ @Resource private TEvaluationTagClient evaluationTagClient; @Resource + @Autowired + private AppUserClient appUserClient; + @Autowired + private AppUserCarClient appUserCarClient; + @Autowired private TOrderEvaluateTagMapper orderEvaluateTagMapper; @Resource private TChargingOrderMapper chargingOrderMapper; @@ -70,6 +82,8 @@ + @Autowired + private TOrderEvaluateMapper orderEvaluateMapper; @Override public List<TEvaluationTagVO> getTagCount() { // 查询标签列表 @@ -111,10 +125,42 @@ List<Long> orderIds = tChargingOrders.stream().map(TChargingOrder::getId).collect(Collectors.toList()); query.setOrderIds(orderIds); List<TOrderEvaluateVO> list = this.baseMapper.pageList(query,pageInfo); + // 查询用户信息 + List<TAppUser> appUsers = appUserClient.getUserByIds(list.stream().map(TOrderEvaluateVO::getAppUserId).collect(Collectors.toList())).getData(); + // 查询用户绑定车辆品牌 + List<TAppUserCar> appUserCars = appUserCarClient.getCarByIds(list.stream().map(TOrderEvaluateVO::getAppUserCarId).collect(Collectors.toList())).getData(); + list.forEach(orderEvaluateVO -> { + TAppUser appUser = appUsers.stream().filter(user -> user.getId().equals(orderEvaluateVO.getAppUserId())).findFirst().orElse(null); + if(Objects.nonNull(appUser)){ + orderEvaluateVO.setName(appUser.getName()); + orderEvaluateVO.setAvatar(appUser.getAvatar()); + } + TAppUserCar appUserCar = appUserCars.stream().filter(car -> car.getId().equals(Long.parseLong(String.valueOf(orderEvaluateVO.getAppUserCarId())))).findFirst().orElse(null); + if(Objects.nonNull(appUserCar)){ + orderEvaluateVO.setCarName(appUserCar.getVehicleBrand()); + } + }); pageInfo.setRecords(list); return pageInfo; } + @Override + public SiteDetailEvaluateVO getSiteDetailEveList(Integer siteId) { + SiteDetailEvaluateVO siteDetailEvaluateVO = new SiteDetailEvaluateVO(); + // 查询站点下的所有订单评价 + List<TOrderEvaluateVO> tChargingOrders = orderEvaluateMapper.getOrderEvaluateBySiteId(siteId); + if(!CollectionUtils.isEmpty(tChargingOrders)){ + siteDetailEvaluateVO.setOrderEvaluateVOS(tChargingOrders); + // 统计好评率 + long goodCount = tChargingOrders.stream().filter(orderEvaluateVO -> orderEvaluateVO.getMark()>=4).count(); + BigDecimal reviewRate = new BigDecimal(goodCount).divide(new BigDecimal(tChargingOrders.size())).setScale(2, BigDecimal.ROUND_HALF_UP); + siteDetailEvaluateVO.setReviewRate(reviewRate); + siteDetailEvaluateVO.setEvaluateCount(tChargingOrders.size()); + siteDetailEvaluateVO.setOrderEvaluateVOS(tChargingOrders.stream().limit(3).collect(Collectors.toList())); + } + return siteDetailEvaluateVO; + } + /** * 统计有图,好评,中差评数量 * @param count -- Gitblit v1.7.1