From 5d7b65670282a4fad015e37d567cfa171b162052 Mon Sep 17 00:00:00 2001
From: huliguo <2023611923@qq.com>
Date: 星期二, 20 五月 2025 12:25:19 +0800
Subject: [PATCH] 基础代码
---
pt-errand/src/main/java/com/ruoyi/errand/service/impl/OrderServiceImpl.java | 607 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 607 insertions(+), 0 deletions(-)
diff --git a/pt-errand/src/main/java/com/ruoyi/errand/service/impl/OrderServiceImpl.java b/pt-errand/src/main/java/com/ruoyi/errand/service/impl/OrderServiceImpl.java
new file mode 100644
index 0000000..a6ebf4c
--- /dev/null
+++ b/pt-errand/src/main/java/com/ruoyi/errand/service/impl/OrderServiceImpl.java
@@ -0,0 +1,607 @@
+package com.ruoyi.errand.service.impl;
+
+import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.common.core.domain.R;
+import com.ruoyi.common.exception.ServiceException;
+import com.ruoyi.common.utils.StringUtils;
+import com.ruoyi.errand.constant.DelFlagConstant;
+import com.ruoyi.errand.domain.AddressBook;
+import com.ruoyi.errand.domain.AppUser;
+import com.ruoyi.errand.domain.Community;
+import com.ruoyi.errand.domain.Order;
+import com.ruoyi.errand.mapper.AddressBookMapper;
+import com.ruoyi.errand.mapper.AppUserMapper;
+import com.ruoyi.errand.mapper.CommunityMapper;
+import com.ruoyi.errand.mapper.OrderMapper;
+import com.ruoyi.errand.object.dto.app.ConfirmOrderDTO;
+import com.ruoyi.errand.object.dto.app.OrderStatsVO;
+import com.ruoyi.errand.object.dto.app.SetConfirmOrderDTO;
+import com.ruoyi.errand.object.dto.sys.FinanceStatisticsDTO;
+import com.ruoyi.errand.object.dto.sys.OrderPageListDTO;
+import com.ruoyi.errand.object.vo.app.AppUserOrderListVO;
+import com.ruoyi.errand.object.vo.app.ConfirmOrderVO;
+import com.ruoyi.errand.object.vo.app.OrderDetailVO;
+import com.ruoyi.errand.object.vo.app.OrderTopInfoVO;
+import com.ruoyi.errand.object.vo.sys.FinanceStatisticsVO;
+import com.ruoyi.errand.object.vo.sys.OrderPageListVO;
+import com.ruoyi.errand.object.vo.sys.OrderSysDetailVO;
+import com.ruoyi.errand.object.vo.sys.UserStatsVO;
+import com.ruoyi.errand.service.OrderService;
+import com.ruoyi.errand.utils.*;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.security.core.context.SecurityContextHolder;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.text.SimpleDateFormat;
+import java.time.*;
+import java.time.format.DateTimeFormatter;
+import java.time.temporal.ChronoUnit;
+import java.time.temporal.TemporalUnit;
+import java.util.*;
+import java.util.stream.Collectors;
+
+@Slf4j
+@Service
+public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements OrderService {
+
+ @Resource
+ private AddressBookMapper addressBookMapper;
+
+ @Resource
+ private CommunityMapper communityMapper;
+ @Autowired
+ private RedisTemplate redisTemplate;
+ @Autowired
+ private AppUserMapper appUserMapper;
+ @Resource
+ private DeliveryWebSocket deliveryWebSocket;
+
+ @Override
+ public ConfirmOrderVO confirmOrder(ConfirmOrderDTO confirmOrderDTO) {
+
+ ConfirmOrderVO confirmOrderVO = new ConfirmOrderVO();
+ BeanUtils.copyProperties(confirmOrderDTO, confirmOrderVO);
+
+ //小区是否存在
+ Community community = communityMapper.selectById(confirmOrderDTO.getCommodityId());
+ if (community==null||community.getDelFlag().equals(DelFlagConstant.DELETE)){
+ throw new ServiceException("小区不存在");
+ }
+ if (community.getStatus()==1){
+ throw new ServiceException("小区已被冻结");
+ }
+ //将地址簿信息查询出来
+ AddressBook addressBook = addressBookMapper.selectById(confirmOrderDTO.getAddressBookId());
+ confirmOrderVO.setRecipientName(addressBook.getRecipientName());
+ confirmOrderVO.setRecipientPhone(addressBook.getRecipientPhone());
+ confirmOrderVO.setAddressDetail(addressBook.getAddressDetail());
+
+ //查询用户信息，设置用户支付信息
+ AppUser appuser = (AppUser) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
+ confirmOrderVO.setCommunityId(confirmOrderDTO.getCommodityId());
+ confirmOrderVO.setCommunityName(community.getName());
+ //两种支付方式
+ if (confirmOrderDTO.getPayMethod()==0){
+ confirmOrderVO.setPayMethod(0);
+ //在线支付
+ confirmOrderVO.setOrderAmount(community.getFeeAmount());//订单金额
+ confirmOrderVO.setPaymentAmount(community.getFeeAmount());//支付金额
+
+ }else if (confirmOrderDTO.getPayMethod()==1){
+ confirmOrderVO.setPayMethod(1);
+ //会员支付
+ if (appuser.getEndTime().isAfter(LocalDateTime.now())) {
+ //过期了
+ throw new ServiceException("支付错误：会员已到期");
+ }
+ confirmOrderVO.setOrderAmount(community.getFeeAmount());
+ confirmOrderVO.setPaymentAmount(BigDecimal.ZERO.setScale(2, RoundingMode.HALF_UP));//支付金额
+
+ }else {
+ throw new ServiceException("支付方式错误");
+ }
+
+ return confirmOrderVO;
+
+
+ }
+
+ @Override
+ public R orderPayment(ConfirmOrderDTO confirmOrderDTO) {
+ Order order = new Order();
+ BeanUtils.copyProperties(confirmOrderDTO, order);
+ //小区是否存在
+ Community community = communityMapper.selectById(confirmOrderDTO.getCommodityId());
+ if (community==null||community.getDelFlag().equals(DelFlagConstant.DELETE)){
+ throw new ServiceException("小区不存在");
+ }
+ if (community.getStatus()==1){
+ throw new ServiceException("小区已被冻结");
+ }
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
+ order.setOrderNumber("QJS" + getNumber(3) + sdf.format(new Date()));
+
+ //将地址簿信息查询出来
+ AddressBook addressBook = addressBookMapper.selectById(confirmOrderDTO.getAddressBookId());
+ order.setRecipientName(addressBook.getRecipientName());
+ order.setRecipientPhone(addressBook.getRecipientPhone());
+ order.setAddressDetail(addressBook.getAddressDetail());
+
+ //查询用户信息，设置用户支付信息
+ AppUser appuser = (AppUser) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
+ if (appuser.getFirstOrder()==1){
+ appuser.setFirstOrder(0);
+ appUserMapper.updateById(appuser);
+ }
+ order.setAppUserId(appuser.getId());
+ order.setCommunityId(confirmOrderDTO.getCommodityId());
+ order.setCommunityName(community.getName());
+
+ order.setPayMethod(confirmOrderDTO.getPayMethod());//支付方式
+ order.setPayStatus(1);//待付款
+
+ //两种支付方式
+ if (confirmOrderDTO.getPayMethod()==0){
+ order.setPayMethod(0);
+ //在线支付
+ order.setOrderAmount(community.getFeeAmount());//订单金额
+ order.setPaymentAmount(community.getFeeAmount());//支付金额
+
+ }else if (confirmOrderDTO.getPayMethod()==1){
+ order.setPayMethod(1);
+ if (appuser.getEndTime().isBefore(LocalDateTime.now())) {
+ //过期了
+ throw new ServiceException("支付错误：会员已到期");
+ }
+ order.setOrderAmount(community.getFeeAmount());
+ order.setPaymentAmount(BigDecimal.ZERO.setScale(2, RoundingMode.HALF_UP));//支付金额
+ }else {
+ throw new ServiceException("支付方式错误");
+ }
+ this.save(order);//先保存订单
+
+
+ //判断需要支付的金额是否大于0
+ BigDecimal paymentMoney = order.getPaymentAmount();
+ if ( BigDecimal.ZERO.compareTo(paymentMoney) < 0){
+ //调起微信支付
+ String agencyMatters = order.getAgencyMatters();
+ UniPayResult uniPayResult = PaymentUtil.uniPay(order.getOrderNumber(), paymentMoney.doubleValue(), "代办事项",
+ agencyMatters, "", "/app/order/orderPaymentCallback", appuser.getWxOpenid(), null);
+ if(null == uniPayResult || !"100".equals(uniPayResult.getRa_Code())){
+ return R.fail(null == uniPayResult ? "支付失败" : uniPayResult.getRb_CodeMsg());
+ }
+ String rc_result = uniPayResult.getRc_Result();
+ JSONObject jsonObject = JSON.parseObject(rc_result);
+ jsonObject.put("orderId", order.getId().toString());
+ //将支付数据添加到redis队列中，便于定时任务去校验是否完成支付，没有完成支付支付，15分钟后关闭订单。
+ long second = LocalDateTime.now().plusMinutes(15).toEpochSecond(ZoneOffset.UTC);
+ redisTemplate.opsForZSet().add("OrderPayment", order.getOrderNumber(), second);
+ return R.ok(jsonObject.toJSONString());
+ }
+
+ //会员支付或支付金额为0直接支付成功
+ order.setOrderStatus(1);//待确认
+ order.setPayStatus(2);//已支付
+ order.setOrderTime(LocalDateTime.now());//下单时间
+ this.updateById(order);
+ Map<String,Object> courier= appUserMapper.getCourierByCommunityId(order.getCommunityId());
+ if (courier == null || courier.isEmpty()) {
+ log.warn("未找到社区ID={}对应的骑手", order.getCommunityId());
+ return R.ok();
+ }
+ //todo 短信通知
+ sendSmsNotificationToCourier(courier,order);
+ //小程序弹窗通知
+ notifyDeliveryPerson((Long) courier.get("id"), order,1);//1=新订单
+
+ //登录访问
+ return R.ok(order.getId().toString());
+ }
+
+
+ /**
+ * 发送短信通知给骑手
+ */
+ private void sendSmsNotificationToCourier(Map<String, Object> courier, Order order) {
+ try {
+ String phoneNumber = (String) courier.get("phone");
+ if (StringUtils.isBlank(phoneNumber)) {
+ log.warn("骑手手机号为空，无法发送短信通知");
+ return;
+ }
+// String content = String.format("您有新的跑腿订单(订单号:%s)，请及时处理!", order.getOrderNumber());
+ //todo 调用短信服务API
+// SMSUtil.sendSms(order.getOrderNumber(),phoneNumber, "", "");
+ log.info("已发送短信通知给骑手: {}", phoneNumber);
+ } catch (Exception e) {
+ log.error("发送短信通知失败", e);
+ }
+ }
+
+ /**
+ * 发送弹窗通知
+ */
+ private void notifyDeliveryPerson(Long deliveryPersonId, Order order,Integer type) {
+ JSONObject message = new JSONObject();
+ message.put("type",type==1?"new_order":"update_order");
+ message.put("orderId", order.getId());
+ message.put("orderTime", order.getOrderTime());
+ deliveryWebSocket.sendNotification(deliveryPersonId.toString(), message.toJSONString());
+ }
+
+ @Override
+ public R orderPaymentCallback(UniPayCallbackResult uniPayCallbackResult) {
+ Order order = this.getBaseMapper().selectOne(new LambdaQueryWrapper<Order>().eq(Order::getOrderNumber, uniPayCallbackResult.getR2_OrderNo()));
+ if(null == order || order.getPayStatus() == 2){
+ return R.ok();
+ }
+ order.setOrderStatus(1);//待确认
+ order.setPayStatus(2);//已支付
+ order.setOrderTime(LocalDateTime.now());//下单时间
+ String r7TrxNo = uniPayCallbackResult.getR9_BankTrxNo();
+ order.setSerialNumber(r7TrxNo);
+ this.updateById(order);
+
+ Map<String,Object> courier= appUserMapper.getCourierByCommunityId(order.getCommunityId());
+ if (courier == null || courier.isEmpty()) {
+ log.warn("未找到社区ID={}对应的骑手", order.getCommunityId());
+ return R.ok();
+ }
+ //todo 短信通知
+ sendSmsNotificationToCourier(courier,order);
+ //小程序弹窗通知
+ notifyDeliveryPerson((Long) courier.get("id"), order,1);//1=新订单
+ return R.ok();
+ }
+
+ /**
+ * 定时任务关闭订单
+ */
+ @Override
+ public void closeOrder() {
+ //订单支付数据
+ long second = LocalDateTime.now().toEpochSecond(ZoneOffset.UTC);
+ Set<String> orderPayment = redisTemplate.opsForZSet().rangeByScore("OrderPayment", 0, second);
+ if(orderPayment.size() > 0){
+ List<Order> list = this.getBaseMapper().selectList(new LambdaQueryWrapper<Order>().in(Order::getOrderNumber, orderPayment));
+ for (Order order : list) {
+ if(null == order || order.getPayStatus() != 1){
+ //不在待支付中的，移除
+ redisTemplate.opsForZSet().remove("OrderPayment", order.getOrderNumber());
+ continue;
+ }
+ //开始执行关闭订单操作
+ CloseOrderResult closeOrderResult = PaymentUtil.closeOrder(order.getOrderNumber());
+ if((null == closeOrderResult || !closeOrderResult.getRa_Status().equals("100")) &&
+ Arrays.asList("0", "4", "101", "10080000", "10080002", "10083004", "10083005").contains(closeOrderResult.getRb_Code())){
+ redisTemplate.opsForZSet().add("OrderPayment", order.getOrderNumber(), 0);
+ log.error("关闭订单失败：{}---->{}", order.getOrderNumber(), JSON.toJSONString(closeOrderResult));
+ }
+ redisTemplate.opsForZSet().remove("OrderPayment", order.getOrderNumber());
+ //删除订单
+ order.setDelFlag(DelFlagConstant.DELETE);
+ this.updateById(order);
+ }
+ }
+
+ }
+
+ @Override
+ public IPage<AppUserOrderListVO> getAppUserOrderList(Integer pageNum, Integer pageSize, Integer orderStatus) {
+ IPage<Order> page = new Page<>(pageNum, pageSize);
+ AppUser appuser = (AppUser) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
+ return this.baseMapper.getAppUserOrderList(page,orderStatus,appuser.getId());
+ }
+
+ @Override
+ public OrderDetailVO getOrderDetail(Integer id) {
+ return this.baseMapper.getOrderDetail(id);
+ }
+
+ @Override
+ public void setOrderInfo(SetConfirmOrderDTO setConfirmOrderDTO) {
+ AppUser appuser = (AppUser) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
+ //判断订单是否存在
+ Order order = this.getById(setConfirmOrderDTO.getId());
+ if (order==null
+ ||order.getDelFlag().equals(DelFlagConstant.DELETE)
+ ||!Objects.equals(order.getAppUserId(), appuser.getId())){
+ throw new ServiceException("订单id错误");
+ }
+ if (order.getOrderStatus()!=1){
+ throw new ServiceException("订单状态错误");
+ }
+ //判断地址簿id是否存在
+ if (setConfirmOrderDTO.getAddressBookId()!=null){
+ AddressBook addressBook = addressBookMapper.selectById(setConfirmOrderDTO.getAddressBookId());
+ if (addressBook==null||addressBook.getDel_flag().equals(DelFlagConstant.DELETE)){
+ throw new ServiceException("该地址簿id不存在");
+ }
+ if (!Objects.equals(addressBook.getCommunityId(), order.getCommunityId())){
+ throw new ServiceException("不能更改为其他小区");
+ }
+ order.setRecipientPhone(addressBook.getRecipientPhone());
+ order.setRecipientName(addressBook.getRecipientName());
+ order.setAddressDetail(addressBook.getAddressDetail());
+ }
+ //代办事项等更改
+ if (setConfirmOrderDTO.getNum()!=null){
+ order.setNum(setConfirmOrderDTO.getNum());
+ }
+ if (setConfirmOrderDTO.getRemark()!=null){
+ order.setRemark(setConfirmOrderDTO.getRemark());
+ }
+ if (setConfirmOrderDTO.getAgencyMatters()!=null){
+ order.setAgencyMatters(setConfirmOrderDTO.getAgencyMatters());
+ }
+ if (setConfirmOrderDTO.getPics()!=null){
+ order.setPics(setConfirmOrderDTO.getPics());
+ }
+ //修改
+ this.updateById(order);
+
+ Map<String,Object> courier= appUserMapper.getCourierByCommunityId(order.getCommunityId());
+ if (courier == null || courier.isEmpty()) {
+ log.warn("未找到社区ID={}对应的骑手", order.getCommunityId());
+ return;
+ }
+ //小程序弹窗通知
+ notifyDeliveryPerson((Long) courier.get("id"), order,2);//2=修改订单
+ }
+
+ @Override
+ public void cancelOrder(Integer id) {
+ //判断订单
+ AppUser appuser = (AppUser) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
+ //判断订单是否存在
+ Order order = this.getById(id);
+ if (order==null
+ ||order.getDelFlag().equals(DelFlagConstant.DELETE)
+ ||!Objects.equals(order.getAppUserId(), appuser.getId())){
+ throw new ServiceException("订单id错误");
+ }
+ //判断状态
+ if (order.getOrderStatus()!=1){
+ throw new ServiceException("订单状态错误");
+ }
+ //判断支付类型
+ if ( order.getPayMethod()==0){
+ //在线支付 回退
+ order.setOrderStatus(3);//已取消
+ R r = refundPayMoney(order);//退款
+ if (200 == r.getCode()) {
+ this.updateById(order);
+ }
+ }else {
+ order.setOrderStatus(3);//已取消
+ this.updateById(order);
+ }
+
+ }
+
+ @Override
+ public R refundPayMoneyCallback(RefundCallbackResult refundCallbackResult) {
+ String code = refundCallbackResult.getR3_RefundOrderNo().substring(1);
+ Order order = this.getOne(new LambdaQueryWrapper<Order>().eq(Order::getOrderNumber, code));
+ if (null == order || order.getPayStatus() == 1 || order.getOrderStatus() == 6) {
+ return R.ok();
+ }
+ order.setRefundCode(refundCallbackResult.getR5_RefundTrxNo());
+ order.setRefundStatus(2);
+ order.setRefundTime(LocalDateTime.now());
+ this.updateById(order);
+ return R.ok();
+ }
+
+ @Override
+ public OrderTopInfoVO orderTopInfo(Integer communityId) {
+
+ OrderTopInfoVO orderTopInfoVO = new OrderTopInfoVO();
+ //总金额
+ Map<String, Object> total = this.baseMapper.getOrderTopInfoByDate(communityId,null,null);
+ orderTopInfoVO.setTodayOrderNum(Integer.valueOf(String.valueOf(total.get("num"))) );
+ orderTopInfoVO.setTotalOrderAmount(new BigDecimal(String.valueOf(total.get("amount"))));
+
+ //今日
+ LocalDateTime now = LocalDateTime.now();
+ LocalDateTime start = now.with(LocalTime.MIN);
+ LocalDateTime end = now.with(LocalTime.MAX);
+ Map<String, Object> today = this.baseMapper.getOrderTopInfoByDate(communityId,start,end);
+ orderTopInfoVO.setTodayOrderNum(Integer.valueOf(String.valueOf(today.get("num"))));
+ orderTopInfoVO.setTodayOrderAmount(new BigDecimal(String.valueOf(today.get("amount"))));
+
+ //当月
+ YearMonth currentMonth = YearMonth.now();
+ start = currentMonth.atDay(1).atStartOfDay();
+ end = currentMonth.atEndOfMonth().atTime(LocalTime.MAX);
+ Map<String, Object> mouth = this.baseMapper.getOrderTopInfoByDate(communityId,start,end);
+ orderTopInfoVO.setMouthOrderNum(Integer.valueOf(String.valueOf(mouth.get("num"))));
+ orderTopInfoVO.setMouthOrderAmount(new BigDecimal(String.valueOf(mouth.get("amount"))));
+
+ //本季度
+ YearMonth thisMonth = YearMonth.now();
+ YearMonth firstMonthOfQuarter = thisMonth.with(
+ Month.of(((thisMonth.getMonthValue() - 1) / 3) * 3 + 1));
+ YearMonth lastMonthOfQuarter = firstMonthOfQuarter.plusMonths(2);
+ start = firstMonthOfQuarter.atDay(1).atStartOfDay();
+ end = lastMonthOfQuarter.atEndOfMonth().atTime(LocalTime.MAX) ;
+ Map<String, Object> quarter = this.baseMapper.getOrderTopInfoByDate(communityId,start,end);
+ orderTopInfoVO.setQuarterOrderNum(Integer.valueOf(String.valueOf(quarter.get("num"))));
+ orderTopInfoVO.setQuarterOrderAmount(new BigDecimal(String.valueOf(quarter.get("amount"))));
+
+ //本年
+ int year = Year.now().getValue();
+ start = LocalDateTime.of(year, 1, 1, 0, 0); // 1月1日
+ end = LocalDateTime.of(year, 12, 31, 23, 59, 59); // 12月31日
+ Map<String, Object> currentYear = this.baseMapper.getOrderTopInfoByDate(communityId,start,end);
+ orderTopInfoVO.setYearOrderNum(Integer.valueOf(String.valueOf(currentYear.get("num"))));
+ orderTopInfoVO.setYearOrderAmount(new BigDecimal(String.valueOf(currentYear.get("amount"))));
+ return orderTopInfoVO;
+ }
+
+ @Override
+ public OrderStatsVO getOrderStats(LocalDateTime start, LocalDateTime end, String datePattern, Integer communityId) {
+ OrderStatsVO orderStatsVO = new OrderStatsVO();
+ // 1. 查询按时间分组的用户数
+ List<Map<String, Object>> stats = this.getBaseMapper().countGroupByDate(start, end, datePattern , communityId);
+
+ // 2. 生成完整的日期序列并填充数据
+ fillDateAndValue(orderStatsVO, start, end, datePattern, stats);
+
+ return orderStatsVO;
+ }
+
+ @Override
+ public IPage<FinanceStatisticsVO> financeStatistics(FinanceStatisticsDTO dto) {
+ //查询出总的数量
+ IPage<FinanceStatisticsVO> page = new Page<>();
+ page.setTotal(this.getBaseMapper().selectPageTotal(dto));
+ List<FinanceStatisticsVO> list=this.getBaseMapper().financeStatistics(dto);
+ page.setRecords(list);
+ page.setSize(dto.getPageSize());
+ page.setCurrent(dto.getPageNum());
+ return page;
+ }
+
+ @Override
+ public List<FinanceStatisticsVO> export(FinanceStatisticsDTO dto) {
+ return this.getBaseMapper().export(dto);
+ }
+
+
+
+ @Override
+ public IPage<OrderPageListVO> getOrderPageList(OrderPageListDTO dto) {
+ IPage<OrderPageListVO> page = new Page<>(dto.getPageNum(),dto.getPageSize());
+ return this.getBaseMapper().getOrderPageList(page,dto);
+ }
+
+ @Override
+ public OrderSysDetailVO detail(Integer id) {
+ return this.getBaseMapper().detail(id);
+ }
+
+ @Override
+ public List<OrderPageListVO> orderExport(OrderPageListDTO dto) {
+
+ return this.getBaseMapper().orderExport(dto);
+ }
+
+ /**
+ * 填充空余时间
+ */
+ private void fillDateAndValue(OrderStatsVO vo, LocalDateTime start, LocalDateTime end,
+ String datePattern, List<Map<String, Object>> stats) {
+ List<String> allDates = generateDateRange(start, end, datePattern);
+ Map<String, Integer> numMap = convertNumsToMap(stats);
+ Map<String, BigDecimal> amountMap = convertAmountToMap(stats);
+
+ List<String> dates = new ArrayList<>();
+ List<Integer> nums = new ArrayList<>();
+
+ List<BigDecimal> amounts = new ArrayList<>();
+
+ for (String date : allDates) {
+ dates.add(date);
+ nums.add(numMap.getOrDefault(date, 0)); // 无数据的日期补0
+ amounts.add(amountMap.getOrDefault(date,BigDecimal.ZERO.setScale(2, BigDecimal.ROUND_HALF_UP)));
+ }
+
+ vo.setDate(dates);
+ vo.setNumList(nums);
+ vo.setAmountList(amounts);
+ }
+ private Map<String, Integer> convertNumsToMap(List<Map<String, Object>> stats) {
+ return stats.stream()
+ .collect(Collectors.toMap(
+ stat -> String.valueOf(stat.get("date")),
+ stat -> Integer.valueOf(String.valueOf(stat.get("num")))
+ ));
+ }
+
+ private Map<String, BigDecimal> convertAmountToMap(List<Map<String, Object>> stats) {
+ return stats.stream()
+ .collect(Collectors.toMap(
+ stat -> String.valueOf(stat.get("date")),
+ stat -> new BigDecimal(String.valueOf(stat.get("amount")))
+ ));
+ }
+
+ private List<String> generateDateRange(LocalDateTime start, LocalDateTime end, String datePattern) {
+ List<String> dates = new ArrayList<>();
+ DateTimeFormatter formatter = DateTimeFormatter.ofPattern(datePattern);
+
+ TemporalUnit unit = getTemporalUnit(datePattern);
+ LocalDateTime current = getInitialDateTime(start, datePattern);
+
+ while (!current.isAfter(end)) {
+ dates.add(current.format(formatter));
+ current = incrementDateTime(current, unit);
+ }
+
+ return dates;
+ }
+
+ private TemporalUnit getTemporalUnit(String datePattern) {
+ switch (datePattern) {
+ case "HH时": return ChronoUnit.HOURS;
+ case "EEEE":
+ case "dd日":
+ case "yyyy-MM-dd": return ChronoUnit.DAYS;
+ case "MM月": return ChronoUnit.MONTHS;
+ default: return ChronoUnit.DAYS;
+ }
+ }
+
+ private LocalDateTime getInitialDateTime(LocalDateTime datetime, String datePattern) {
+ switch (datePattern) {
+ case "HH时": return datetime.withMinute(0).withSecond(0).withNano(0);
+ case "MM月": return datetime.withDayOfMonth(1);
+ default: return datetime;
+ }
+ }
+
+ private LocalDateTime incrementDateTime(LocalDateTime current, TemporalUnit unit) {
+ if (unit == ChronoUnit.HOURS) return current.plusHours(1);
+ if (unit == ChronoUnit.DAYS) return current.plusDays(1);
+ if (unit == ChronoUnit.MONTHS) return current.plusMonths(1);
+ return current.plusDays(1);
+ }
+ /**
+ * 返回订单支付金额
+ */
+ public R refundPayMoney(Order order) {
+ //开始退款
+ BigDecimal paymentAmount = order.getPaymentAmount();
+ if (BigDecimal.ZERO.compareTo(order.getPaymentAmount()) < 0) {//支付的金额是否大于0
+ //微信退款
+ RefundResult refund = PaymentUtil.refund(order.getOrderNumber(), "R" + order.getOrderNumber(), paymentAmount.doubleValue(),
+ "/app/order/refundPayMoneyCallback");
+ if (!"100".equals(refund.getRa_Status())) {
+ return R.fail(refund.getRc_CodeMsg());//退款失败
+ }
+ }
+ return R.ok();
+ }
+
+
+ public String getNumber(Integer size){
+ StringBuilder str = new StringBuilder();
+ for (int i = 0; i < size; i++) {
+ str.append(Double.valueOf(Math.random() * 10).intValue());
+ }
+ return str.toString();
+ }
+}
\ No newline at end of file
--
Gitblit v1.7.1