From c3363d35b8dd42a862681d505360cd2c72d070a1 Mon Sep 17 00:00:00 2001 From: zhibing.pu <393733352@qq.com> Date: 星期六, 10 八月 2024 18:11:39 +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 | 84 ++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 84 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 c636186..b1b5ca5 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 @@ -1,10 +1,28 @@ package com.ruoyi.order.service.impl; +import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.chargingPile.api.vo.TAccountingStrategyVO; +import com.ruoyi.common.core.domain.R; +import com.ruoyi.common.core.web.page.PageInfo; +import com.ruoyi.order.api.model.TChargingOrder; import com.ruoyi.order.api.model.TOrderEvaluate; +import com.ruoyi.order.api.query.TOrderEvaluateQuery; +import com.ruoyi.order.api.vo.TOrderEvaluateVO; +import com.ruoyi.order.mapper.TChargingOrderMapper; import com.ruoyi.order.mapper.TOrderEvaluateMapper; +import com.ruoyi.order.mapper.TOrderEvaluateTagMapper; import com.ruoyi.order.service.TOrderEvaluateService; +import com.ruoyi.other.api.feignClient.TEvaluationTagClient; +import com.ruoyi.other.api.vo.TEvaluationTagVO; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.util.CollectionUtils; + +import java.util.Comparator; +import java.util.List; +import java.util.Map; +import java.util.stream.Collectors; /** * <p> @@ -17,4 +35,70 @@ @Service public class TOrderEvaluateServiceImpl extends ServiceImpl<TOrderEvaluateMapper, TOrderEvaluate> implements TOrderEvaluateService { + @Autowired + private TEvaluationTagClient evaluationTagClient; + @Autowired + private TOrderEvaluateTagMapper orderEvaluateTagMapper; + @Autowired + private TChargingOrderMapper chargingOrderMapper; + @Override + public List<TEvaluationTagVO> getTagCount() { + // 查询标签列表 + R<List<TEvaluationTagVO>> r = evaluationTagClient.getTagList(); + List<TEvaluationTagVO> tagList = r.getData(); + List<Integer> tagIds = tagList.stream().map(TEvaluationTagVO::getId).collect(Collectors.toList()); + // 统计标签使用数量 + List<TEvaluationTagVO> counts = orderEvaluateTagMapper.getCountByTagIds(tagIds); + tagList.forEach(tag -> { + counts.forEach(count -> { + if (tag.getId().equals(count.getId())) { + tag.setTagCount(count.getTagCount()); + } + }); + }); + tagList = tagList.stream().sorted(Comparator.comparing(TEvaluationTagVO::getTagCount).reversed()).collect(Collectors.toList()); + // 统计有图,好评,中差评数量 + long imgUrlCount = this.count(Wrappers.lambdaQuery(TOrderEvaluate.class) + .isNotNull(TOrderEvaluate::getImgUrl)); + packageTagCount(imgUrlCount,"有图",tagList); + long goodCount = this.count(Wrappers.lambdaQuery(TOrderEvaluate.class) + .ge(TOrderEvaluate::getMark,4)); + packageTagCount(goodCount,"好评",tagList); + long badCount = this.count(Wrappers.lambdaQuery(TOrderEvaluate.class) + .le(TOrderEvaluate::getMark,3)); + packageTagCount(badCount,"中差评",tagList); + return tagList; + } + + @Override + public PageInfo<TOrderEvaluateVO> getTagList(TOrderEvaluateQuery query) { + PageInfo<TOrderEvaluateVO> pageInfo = new PageInfo<>(query.getPageCurr(),query.getPageSize()); + // 查询站点下的所有订单 + List<TChargingOrder> tChargingOrders = chargingOrderMapper.selectList(Wrappers.lambdaQuery(TChargingOrder.class) + .eq(TChargingOrder::getSiteId, query.getSiteId())); + if(CollectionUtils.isEmpty(tChargingOrders)){ + return new PageInfo<>(); + } + List<Long> orderIds = tChargingOrders.stream().map(TChargingOrder::getId).collect(Collectors.toList()); + query.setOrderIds(orderIds); + List<TOrderEvaluateVO> list = this.baseMapper.pageList(query,pageInfo); + pageInfo.setRecords(list); + return pageInfo; + } + + /** + * 统计有图,好评,中差评数量 + * @param count + * @param name + * @param tagList + */ + private void packageTagCount(Long count,String name,List<TEvaluationTagVO> tagList){ + if(count>0){ + TEvaluationTagVO evaluationTagVO = new TEvaluationTagVO(); + evaluationTagVO.setName(name); + evaluationTagVO.setTagCount(Integer.parseInt(String.valueOf(count))); + tagList.add(evaluationTagVO); + } + } + } -- Gitblit v1.7.1