package cn.iocoder.yudao.module.statistics.service.trade;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.date.LocalDateTimeUtil;
|
import cn.iocoder.yudao.module.statistics.controller.admin.common.vo.DataComparisonRespVO;
|
import cn.iocoder.yudao.module.statistics.controller.admin.trade.vo.TradeOrderSummaryRespVO;
|
import cn.iocoder.yudao.module.statistics.controller.admin.trade.vo.TradeOrderTrendReqVO;
|
import cn.iocoder.yudao.module.statistics.controller.admin.trade.vo.TradeOrderTrendRespVO;
|
import cn.iocoder.yudao.module.statistics.dal.mysql.trade.TradeOrderStatisticsMapper;
|
import cn.iocoder.yudao.module.statistics.enums.TimeRangeTypeEnum;
|
import cn.iocoder.yudao.module.statistics.service.member.bo.MemberAreaStatisticsRespBO;
|
import cn.iocoder.yudao.module.statistics.service.trade.bo.TradeOrderSummaryRespBO;
|
import org.springframework.stereotype.Service;
|
import org.springframework.validation.annotation.Validated;
|
|
import jakarta.annotation.Resource;
|
import java.time.Duration;
|
import java.time.LocalDateTime;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
import java.util.stream.IntStream;
|
|
/**
|
* 交易订单统计 Service 实现类
|
*
|
* @author owen
|
*/
|
@Service
|
@Validated
|
public class TradeOrderStatisticsServiceImpl implements TradeOrderStatisticsService {
|
|
@Resource
|
private TradeOrderStatisticsMapper tradeOrderStatisticsMapper;
|
|
@Override
|
public TradeOrderSummaryRespBO getOrderSummary(LocalDateTime beginTime, LocalDateTime endTime) {
|
return new TradeOrderSummaryRespBO()
|
.setOrderCreateCount(tradeOrderStatisticsMapper.selectCountByCreateTimeBetween(beginTime, endTime))
|
.setOrderPayCount(tradeOrderStatisticsMapper.selectCountByPayTimeBetween(beginTime, endTime))
|
.setOrderPayPrice(tradeOrderStatisticsMapper.selectSummaryPriceByPayTimeBetween(beginTime, endTime));
|
}
|
|
@Override
|
public List<MemberAreaStatisticsRespBO> getSummaryListByAreaId() {
|
return tradeOrderStatisticsMapper.selectSummaryListByAreaId();
|
}
|
|
@Override
|
public Integer getOrderUserCount(LocalDateTime beginTime, LocalDateTime endTime) {
|
return tradeOrderStatisticsMapper.selectUserCountByCreateTimeBetween(beginTime, endTime);
|
}
|
|
@Override
|
public Integer getPayUserCount(LocalDateTime beginTime, LocalDateTime endTime) {
|
return tradeOrderStatisticsMapper.selectUserCountByPayTimeBetween(beginTime, endTime);
|
}
|
|
@Override
|
public Integer getOrderPayPrice(LocalDateTime beginTime, LocalDateTime endTime) {
|
return tradeOrderStatisticsMapper.selectSummaryPriceByPayTimeBetween(beginTime, endTime);
|
}
|
|
@Override
|
public Long getCountByStatusAndDeliveryType(Integer status, Integer deliveryType) {
|
return tradeOrderStatisticsMapper.selectCountByStatusAndDeliveryType(status, deliveryType);
|
}
|
|
@Override
|
public DataComparisonRespVO<TradeOrderSummaryRespVO> getOrderComparison() {
|
return new DataComparisonRespVO<TradeOrderSummaryRespVO>()
|
.setValue(getPayPriceSummary(LocalDateTime.now()))
|
.setReference(getPayPriceSummary(LocalDateTime.now().minusDays(1)));
|
}
|
|
private TradeOrderSummaryRespVO getPayPriceSummary(LocalDateTime date) {
|
LocalDateTime beginTime = LocalDateTimeUtil.beginOfDay(date);
|
LocalDateTime endTime = LocalDateTimeUtil.endOfDay(date);
|
return tradeOrderStatisticsMapper.selectPaySummaryByPayStatusAndPayTimeBetween(
|
Boolean.TRUE, beginTime, endTime);
|
}
|
|
@Override
|
public List<DataComparisonRespVO<TradeOrderTrendRespVO>> getOrderCountTrendComparison(TradeOrderTrendReqVO reqVO) {
|
// 查询当前数据
|
List<TradeOrderTrendRespVO> value = getOrderCountTrend(reqVO.getType(), reqVO.getBeginTime(), reqVO.getEndTime());
|
// 查询对照数据
|
LocalDateTime referenceEndTime = reqVO.getBeginTime().minusDays(1);
|
LocalDateTime referenceBeginTime = referenceEndTime.minus(Duration.between(reqVO.getBeginTime(), reqVO.getEndTime()));
|
List<TradeOrderTrendRespVO> reference = getOrderCountTrend(reqVO.getType(), referenceBeginTime, referenceEndTime);
|
// 顺序对比返回
|
return IntStream.range(0, value.size())
|
.mapToObj(index -> new DataComparisonRespVO<TradeOrderTrendRespVO>()
|
.setValue(CollUtil.get(value, index))
|
.setReference(CollUtil.get(reference, index)))
|
.collect(Collectors.toList());
|
}
|
|
private List<TradeOrderTrendRespVO> getOrderCountTrend(Integer timeRangeType, LocalDateTime beginTime, LocalDateTime endTime) {
|
// 情况一：按年统计时，以月份分组
|
if (TimeRangeTypeEnum.YEAR.getType().equals(timeRangeType)) {
|
return tradeOrderStatisticsMapper.selectListByPayTimeBetweenAndGroupByMonth(beginTime, endTime);
|
}
|
// 情况二：其它以天分组（天、周、月）
|
return tradeOrderStatisticsMapper.selectListByPayTimeBetweenAndGroupByDay(beginTime, endTime);
|
}
|
|
}
|
