package com.ruoyi.order.service.impl;
|
|
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;
|
import com.ruoyi.chargingPile.api.model.Site;
|
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.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;
|
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.domain.TEvaluationTag;
|
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.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;
|
|
/**
|
* <p>
|
* 服务实现类
|
* </p>
|
*
|
* @author xiaochen
|
* @since 2024-08-07
|
*/
|
@Service
|
public class TOrderEvaluateServiceImpl extends ServiceImpl<TOrderEvaluateMapper, TOrderEvaluate> implements TOrderEvaluateService {
|
|
@Resource
|
private TEvaluationTagClient evaluationTagClient;
|
@Resource
|
private AppUserClient appUserClient;
|
@Resource
|
private AppUserCarClient appUserCarClient;
|
@Resource
|
private TOrderEvaluateTagMapper orderEvaluateTagMapper;
|
@Resource
|
private TChargingOrderMapper chargingOrderMapper;
|
|
@Resource
|
private SiteClient siteClient;
|
|
|
|
|
|
|
|
|
|
|
|
|
@Resource
|
private TOrderEvaluateMapper orderEvaluateMapper;
|
@Override
|
public List<TEvaluationTagVO> getTagCount() {
|
// 查询标签列表
|
R<List<TEvaluationTagVO>> r = evaluationTagClient.getTagList(null);
|
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);
|
// 查询用户信息
|
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
|
* @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);
|
}
|
}
|
|
|
/**
|
* 获取充电评价列表
|
* @param pageList
|
* @return
|
*/
|
@Override
|
public PageInfo<GetOrderEvaluatePageListDTO> getPageList(GetOrderEvaluatePageList pageList) {
|
PageInfo<GetOrderEvaluatePageListDTO> pageInfo = new PageInfo<>(pageList.getPageCurr(), pageList.getPageSize());
|
List<Integer> evaluationTagIds = null;
|
if(null != pageList.getEvaluateType()){
|
List<TEvaluationTagVO> data = evaluationTagClient.getTagList(pageList.getEvaluateType()).getData();
|
evaluationTagIds = data.stream().map(TEvaluationTagVO::getId).collect(Collectors.toList());
|
}
|
List<GetOrderEvaluatePageListDTO> list = this.baseMapper.getPageList(pageList, evaluationTagIds, pageInfo);
|
for (GetOrderEvaluatePageListDTO dto : list) {
|
TAppUser appUser = appUserClient.getUserById(dto.getAppUserId()).getData();
|
dto.setAvatar(appUser.getAvatar());
|
String phone = appUser.getPhone();
|
dto.setPhone(phone.substring(0, 3) + "****" + phone.substring(6));
|
Site site = siteClient.getSiteByIds(Arrays.asList(dto.getSiteId())).getData().get(0);
|
dto.setSiteName(site.getName());
|
List<TOrderEvaluateTag> tOrderEvaluateTags = orderEvaluateTagMapper.selectList(new LambdaQueryWrapper<TOrderEvaluateTag>().eq(TOrderEvaluateTag::getOrderEvaluateId, dto.getId()));
|
List<Integer> tagIds = tOrderEvaluateTags.stream().map(TOrderEvaluateTag::getEvaluationTagId).collect(Collectors.toList());
|
List<TEvaluationTag> data = evaluationTagClient.getListByIds(tagIds).getData();
|
List<String> collect = data.stream().map(TEvaluationTag::getName).collect(Collectors.toList());
|
dto.setTags(collect);
|
}
|
return pageInfo.setRecords(list);
|
}
|
}
|
