From e0fc8f7e2230b51e3bbe8dea43790cf11b7170e9 Mon Sep 17 00:00:00 2001 From: luodangjia <luodangjia> Date: 星期一, 04 十一月 2024 15:39:01 +0800 Subject: [PATCH] merge --- ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TShoppingOrderServiceImpl.java | 138 ++++++++++++++++++++++++++++++++++----------- 1 files changed, 104 insertions(+), 34 deletions(-) diff --git a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TShoppingOrderServiceImpl.java b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TShoppingOrderServiceImpl.java index 7f8b25f..5716b77 100644 --- a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TShoppingOrderServiceImpl.java +++ b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TShoppingOrderServiceImpl.java @@ -1,5 +1,6 @@ package com.ruoyi.order.service.impl; +import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; @@ -63,37 +64,37 @@ */ @Service public class TShoppingOrderServiceImpl extends ServiceImpl<TShoppingOrderMapper, TShoppingOrder> implements TShoppingOrderService { - + @Resource private TokenService tokenService; - + @Resource private GoodsClient goodsClient; - + @Resource private CouponClient couponClient; @Resource private AppUserClient appUserClient; - + @Resource private AppUserAddressClient appUserAddressClient; @Resource private AppCouponClient appCouponClient; - + @Resource private WxPaymentClient wxPaymentClient; - + @Resource private AliPaymentClient aliPaymentClient; - + @Resource private TShoppingOrderRefundService shoppingOrderRefundService; - + @Autowired public RedisTemplate redisTemplate; - - - + + + @Override public TActivityVO activityStatistics(TActivityStatisticsQuery dto) { @@ -102,8 +103,10 @@ PageInfo<TActivityStatisticslVO> pageInfo = new PageInfo<>(dto.getPageCurr(),dto.getPageSize()); + PageInfo<TActivityStatisticslVO> pageInfo1 = new PageInfo<>(1,9999999); List<TActivityStatisticslVO> list = this.baseMapper.activityStatistics(pageInfo,dto); - list.sort((o1, o2) -> o2.getCreateTime().compareTo(o1.getCreateTime())); + List<TActivityStatisticslVO> list1 = this.baseMapper.activityStatistics(pageInfo1,dto); + // 优惠券金额 BigDecimal coupon = new BigDecimal("0"); // 会员抵扣金额 @@ -112,9 +115,11 @@ BigDecimal vipActivity = new BigDecimal("0"); // 赠送会员 BigDecimal grantVip = new BigDecimal("0"); - SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - - for (TActivityStatisticslVO tActivityStatisticslVO : list) { + for (TActivityStatisticslVO tActivityStatisticslVO : list1) { + TAppUser data = appUserClient.getUserById(tActivityStatisticslVO.getAppUserId()).getData(); + if (data!=null){ + tActivityStatisticslVO.setPhone(data.getPhone()); + } // 判断享有了哪些类型 switch (tActivityStatisticslVO.getOrderType()){ case 1: @@ -123,10 +128,10 @@ // 充电订单 优惠券金额大于0 if (tActivityStatisticslVO.getCouponDiscountAmount()!=null && - (tActivityStatisticslVO.getCouponDiscountAmount().compareTo(BigDecimal.ZERO)>0)){ + (tActivityStatisticslVO.getCouponDiscountAmount().compareTo(BigDecimal.ZERO)>0)){ coupon = coupon.add(tActivityStatisticslVO.getCouponDiscountAmount()); stringBuilder.append("优惠券抵扣").append("+"); - } + } if (tActivityStatisticslVO.getVipDiscountAmount()!=null &&(tActivityStatisticslVO.getVipDiscountAmount().compareTo(BigDecimal.ZERO)>0)){ discount = discount.add(tActivityStatisticslVO.getVipDiscountAmount()); stringBuilder.append("会员抵扣").append("+"); @@ -161,9 +166,7 @@ break; case 3: // 会员订单 优惠金额大于0 - if (tActivityStatisticslVO.getVipDiscountAmount()!=null - && - (tActivityStatisticslVO.getCouponDiscountAmount().compareTo(BigDecimal.ZERO)>0)){ + if (tActivityStatisticslVO.getVipDiscountAmount()!=null){ vipActivity = vipActivity.add(tActivityStatisticslVO.getVipDiscountAmount()); } tActivityStatisticslVO.setType("会员活动"); @@ -184,6 +187,73 @@ break; } } + + List<Long> appUserIds = list.stream().map(TActivityStatisticslVO::getAppUserId).collect(Collectors.toList()); + List<TAppUser> appUsers = appUserClient.getUserByIds(appUserIds).getData(); + + for (TActivityStatisticslVO tActivityStatisticslVO : list) { + TAppUser appUser = appUsers.stream().filter(user -> user.getId().equals(tActivityStatisticslVO.getAppUserId())).findFirst().orElse(null); + if(Objects.nonNull(appUser)){ + tActivityStatisticslVO.setPhone(appUser.getPhone()); + } + // 判断享有了哪些类型 + switch (tActivityStatisticslVO.getOrderType()){ + case 1: + StringBuilder stringBuilder = new StringBuilder(); + + // 充电订单 优惠券金额大于0 + if (tActivityStatisticslVO.getCouponDiscountAmount()!=null + && + (tActivityStatisticslVO.getCouponDiscountAmount().compareTo(BigDecimal.ZERO)>0)){ + stringBuilder.append("优惠券抵扣").append("+"); + } + if (tActivityStatisticslVO.getVipDiscountAmount()!=null &&(tActivityStatisticslVO.getVipDiscountAmount().compareTo(BigDecimal.ZERO)>0)){ + stringBuilder.append("会员抵扣").append("+"); + } + if (stringBuilder.length()>0){ + stringBuilder.deleteCharAt(stringBuilder.length()-1); + tActivityStatisticslVO.setType(stringBuilder.toString()); + } + tActivityStatisticslVO.setTime(tActivityStatisticslVO.getCreateTime()); + break; + case 2: + StringBuilder stringBuilder1 = new StringBuilder(); + + // 购物订单 优惠券金额大于0 + if (tActivityStatisticslVO.getCouponDiscountAmount()!=null + && + (tActivityStatisticslVO.getCouponDiscountAmount().compareTo(BigDecimal.ZERO)>0)){ + stringBuilder1.append("优惠券抵扣").append("+"); + } + if (tActivityStatisticslVO.getVipDiscountAmount()!=null + && + (tActivityStatisticslVO.getVipDiscountAmount().compareTo(BigDecimal.ZERO)>0)){ + stringBuilder1.append("会员抵扣").append("+"); + } + if (stringBuilder1.length()>0){ + stringBuilder1.deleteCharAt(stringBuilder1.length()-1); + } + tActivityStatisticslVO.setType(stringBuilder1.toString()); + tActivityStatisticslVO.setTime(tActivityStatisticslVO.getCreateTime()); + break; + case 3: + // 会员订单 优惠金额大于0 + tActivityStatisticslVO.setType("会员活动"); + tActivityStatisticslVO.setTime(tActivityStatisticslVO.getCreateTime()); + break; + case 4: + // 赠送会员订单 如果支付金额为0 那么就是后台赠送的会员 + if (tActivityStatisticslVO.getPaymentAmount().compareTo(BigDecimal.ZERO)==0){ + tActivityStatisticslVO.setType("赠送会员"); + tActivityStatisticslVO.setTime(tActivityStatisticslVO.getCreateTime()); + }else{ + // 赠送 + tActivityStatisticslVO.setType("赠送会员"); + tActivityStatisticslVO.setTime(tActivityStatisticslVO.getCreateTime()); + } + break; + } + } pageInfo.setRecords(list); res.setList(pageInfo); res.setTotal(coupon.add(discount).add(vipActivity).add(grantVip)); @@ -193,8 +263,8 @@ res.setGrantVip(grantVip); return res; } - - + + /** * 获取小程序商城购买订单列表 * @param query @@ -241,8 +311,8 @@ map.put("total", count); return map; } - - + + /** * 获取购买订单详情 * @param id @@ -254,7 +324,7 @@ MyShoppingOrderInfo info = new MyShoppingOrderInfo(); info.setId(id); info.setStatus(shoppingOrder.getStatus()); - TAppUserAddress userAddress = appUserAddressClient.getAppUserAddressById(shoppingOrder.getAppUserAddressId()).getData(); + TAppUserAddress userAddress = JSON.parseObject(shoppingOrder.getAddressJson(), TAppUserAddress.class); info.setConsignee(userAddress.getName()); info.setPhone(userAddress.getPhone()); info.setAddress(userAddress.getProvince() + userAddress.getCity() + userAddress.getDistrict() + userAddress.getAddress() + userAddress.getHouseNumber()); @@ -292,8 +362,8 @@ } return info; } - - + + /** * 取消订单 * @param id @@ -314,10 +384,10 @@ if(shoppingOrder.getPaymentAmount().compareTo(bigDecimal) == 0 && shoppingOrder.getStatus() == 4){ return AjaxResult.error("订单已取消,不能重复操作"); } - + //退款金额 BigDecimal refundAmount = shoppingOrder.getPaymentAmount().subtract(bigDecimal); - + //先查询第三方订单状态订单是否退款 //支付方式(1=微信,2=支付宝) Integer paymentType = shoppingOrder.getPaymentType(); @@ -366,7 +436,7 @@ shoppingOrderRefund.setRefundRemark("全额退款"); shoppingOrderRefund.setRefundTotalAmount(refundAmount.add(bigDecimal)); shoppingOrderRefund.setPayAmount(shoppingOrder.getPaymentAmount()); - + shoppingOrder.setCancellationTime(LocalDateTime.now()); shoppingOrder.setCancellationId(shoppingOrder.getAppUserId()); if(1 == paymentType){ @@ -402,8 +472,8 @@ } return AjaxResult.success(); } - - + + /** * 商城订单取消订单微信退款处理 * @param out_refund_no 退款单号 @@ -428,7 +498,7 @@ shoppingOrder.setRefundStatus(2); shoppingOrder.setRefundTime(one.getRefundTime()); this.updateById(shoppingOrder); - + //商品 if(shoppingOrder.getOrderType() == 1){ //redis锁 和支付使用同一个锁 @@ -469,7 +539,7 @@ } return AjaxResult.success(); } - + /** * 获取未开票的订单列表 * @param query -- Gitblit v1.7.1