挂账退款

cash-api/order-server/src/main/java/com/czg/controller/pay/OrderPayController.java

@@ -126,18 +126,18 @@ public class OrderPayController {
         return orderPayService.ltPayOrder(ServletUtil.getClientIP(request), payParam);
     }
 
-    /**
-     * 正扫
-     */
-    @PostMapping("/scanPay")
-    @Debounce(value = "#payParam.checkOrderPay.orderId")
-    public CzgResult<Map<String, Object>> scanPayOrder(@RequestHeader Long shopId, HttpServletRequest request, @Validated @RequestBody OrderPayParamDTO payParam) {
-        payParam.setShopId(shopId);
-        return orderPayService.scanPayOrder(ServletUtil.getClientIP(request), payParam);
-    }
+//    /**
+//     * 正扫
+//     */
+//    @PostMapping("/scanPay")
+//    @Debounce(value = "#payParam.checkOrderPay.orderId")
+//    public CzgResult<Map<String, Object>> scanPayOrder(@RequestHeader Long shopId, HttpServletRequest request, @Validated @RequestBody OrderPayParamDTO payParam) {
+//        payParam.setShopId(shopId);
+//        return orderPayService.scanPayOrder(ServletUtil.getClientIP(request), payParam);
+//    }
 
     /**
-     * 反扫
+     * 扫码收款
      * authCode 必填 扫描码
      */
     @PostMapping("/microPay")

cash-common/cash-common-service/src/main/java/com/czg/order/dto/FinanceStsDTO.java

@@ -67,9 +67,13 @@ public class FinanceStsDTO {
         private BigDecimal alipay;
 
         /**
-         * 主扫收款
+         * 二维码收款
          */
         private BigDecimal selfScan;
+        /**
+         * 扫码收款
+         */
+        private BigDecimal barScan;
 
         /**
          * 现金收款
@@ -182,6 +186,10 @@ public class FinanceStsDTO {
          * 现金退款金额
          */
         private BigDecimal cashRefundAmount;
+        /**
+         * 挂账退款金额
+         */
+        private BigDecimal creditRefundAmount;
 
         /**
          * 充值退款金额

cash-common/cash-common-service/src/main/java/com/czg/order/entity/OrderInfo.java

@@ -182,13 +182,14 @@ public class OrderInfo implements Serializable {
     /**
      * {@link com.czg.order.enums.PayEnums}
      * 支付类型
-     * 主扫 main_scan
-     * 被扫 back_scan
+     * 二维码收款 main_scan
+     * 扫码收款 back_scan
      * 微信小程序 wechat_mini
      * 支付宝小程序 alipay_mini
      * 会员支付 vip_pay
      * 现金支付 cash_pay
      * 挂账支付 credit_pay
+     * 霸王餐支付 free_pay
      */
     private String payType;
 

cash-common/cash-common-service/src/main/java/com/czg/order/entity/OrderPayment.java

@@ -150,9 +150,10 @@ public class OrderPayment implements Serializable {
         return orderPayment;
     }
 
-    public static OrderPayment refund(@NonNull Long shopId, @NonNull Long sourceId, @NotBlank String sourceType,
+    public static OrderPayment refund(@NonNull String channel,@NonNull Long shopId, @NonNull Long sourceId, @NotBlank String sourceType,
                                       @NotBlank String orderNo, @NonNull BigDecimal amount, Long relatedId, String platformType) {
         OrderPayment orderPayment = getInstance(shopId, sourceId, sourceType, orderNo, amount, null, relatedId);
+        orderPayment.setChannel(channel);
         orderPayment.setPayType(PayTypeConstants.PayType.REFUND);
         orderPayment.setPayStatus(PayTypeConstants.PayStatus.INIT);
         orderPayment.setPlatformType(platformType);

cash-common/cash-common-service/src/main/java/com/czg/order/entity/ShopOrderStatistic.java

@@ -169,22 +169,22 @@ public class ShopOrderStatistic implements Serializable {
     /**
      * 被扫收款金额
      */
-    @ExcelProperty("被扫收款金额")
+    @ExcelProperty("扫码收款金额")
     private BigDecimal backScanPayAmount;
     /**
      * 被扫收款笔数
      */
-    @ExcelProperty("被扫收款笔数")
+    @ExcelProperty("扫码收款笔数")
     private Long backScanPayCount;
     /**
-     * 主扫收款金额
+     * 二维码收款金额
      */
-    @ExcelProperty("主扫收款金额")
+    @ExcelProperty("二维码收款金额")
     private BigDecimal mainScanPayAmount;
     /**
-     * 主扫收款笔数
+     * 二维码收款笔数
      */
-    @ExcelProperty("主扫收款笔数")
+    @ExcelProperty("二维码收款笔数")
     private Long mainScanPayCount;
     /**
      * 挂账支付金额
@@ -221,6 +221,8 @@ public class ShopOrderStatistic implements Serializable {
      */
     @ExcelProperty("订单退款金额")
     private BigDecimal refundAmount;
+    @ExcelProperty("订单挂账退款金额")
+    private BigDecimal creditRefundAmount;
     /**
      * 订单退款 线上退款金额
      */

cash-common/cash-common-service/src/main/java/com/czg/order/enums/PayEnums.java

@@ -17,11 +17,12 @@ public enum PayEnums {
     /**
      * 主扫
      */
-    MAIN_SCAN("main_scan", "主扫"),
+    MAIN_SCAN("main_scan", "二维码收款"),
     /**
      * 被扫
      */
-    BACK_SCAN("back_scan", "被扫"),
+//    BACK_SCAN("back_scan", "被扫"),
+    BACK_SCAN("back_scan", "扫码收款"),
     /**
      * 微信小程序
      */

cash-service/order-service/src/main/java/com/czg/service/order/mapper/ShopOrderStatisticMapper.java

@@ -192,7 +192,7 @@ public interface ShopOrderStatisticMapper extends BaseMapper<ShopOrderStatistic>
             "    AND shop_id = #{shopId}" +
             "    AND source_type NOT IN ('memberPay', 'distribution', 'distributionRecharge', 'point' ,'ware')" +
             "    AND pay_type != 'refundCompensate'" +
-            "    AND pay_date = #{tradeDay} ;")
+            "    AND DATE(update_time) = #{tradeDay} ;")
     ShopOrderStatistic getOnlineStatSingleDate(Long shopId, LocalDate tradeDay);
 
     /**
@@ -210,6 +210,7 @@ public interface ShopOrderStatisticMapper extends BaseMapper<ShopOrderStatistic>
             " SUM(CASE WHEN pay_type = 'free_pay' THEN order_amount ELSE 0 END) AS backDiscountAmount," +
             " " +
             " SUM(CASE WHEN pay_type = 'vip_pay' THEN refund_amount ELSE 0 END) AS memberRefundAmount," +
+            " SUM(CASE WHEN pay_type = 'credit_pay' THEN refund_amount ELSE 0 END) AS creditRefundAmount," +
             " " +
             " SUM(CASE WHEN pay_type = 'vip_pay' THEN 1 ELSE 0 END) as memberPayCount," +
             " SUM(CASE WHEN pay_type = 'cash_pay' THEN 1 ELSE 0 END) as cashPayCount," +
@@ -219,15 +220,15 @@ public interface ShopOrderStatisticMapper extends BaseMapper<ShopOrderStatistic>
             " SUM(CASE WHEN pay_type = 'main_scan' THEN 1 ELSE 0 END) as mainScanPayCount," +
             " SUM(CASE WHEN pay_type = 'credit_pay' THEN 1 ELSE 0 END) as creditPayCount," +
             " " +
-            " SUM(refund_amount) as refundAmount," +
+            " IFNULL(SUM(refund_amount), 0) as refundAmount," +
             " SUM(CASE WHEN refund_type = 'cash' or pay_type = 'cash_pay' THEN refund_amount ELSE 0 END) as cashRefundAmount," +
             " " +
-            " SUM(new_customer_discount_amount) as newCustomerDiscountAmount," +
-            " SUM(discount_act_amount) as fullDiscountAmount," +
-            " SUM(product_coupon_discount_amount) + SUM(other_coupon_discount_amount) as couponDiscountAmount," +
-            " SUM(points_discount_amount) as pointDiscountAmount," +
-            " SUM(vip_discount_amount) as memberDiscountAmount," +
-            " SUM(discount_amount) as orderPriceDiscountAmount ," +
+            " IFNULL(SUM(new_customer_discount_amount), 0) as newCustomerDiscountAmount," +
+            " IFNULL(SUM(discount_act_amount), 0) as fullDiscountAmount," +
+            " IFNULL(SUM(product_coupon_discount_amount), 0) + IFNULL(SUM(other_coupon_discount_amount), 0) as couponDiscountAmount," +
+            " IFNULL(SUM(points_discount_amount), 0) as pointDiscountAmount," +
+            " IFNULL(SUM(vip_discount_amount), 0) as memberDiscountAmount," +
+            " IFNULL(SUM(discount_amount), 0) as orderPriceDiscountAmount ," +
             " count(1) as orderCount," +
             " sum(CASE WHEN seat_num IS NULL OR seat_num <= 0 THEN 1 ELSE seat_num END) as customerCount " +
             "FROM" +

cash-service/order-service/src/main/java/com/czg/service/order/service/impl/FinanceStsServiceImpl.java

@@ -36,10 +36,11 @@ public class FinanceStsServiceImpl implements FinanceStsService {
         return new FinanceStsDTO()
                 .setDate(LocalDateTimeUtil.format(param.getQueryDate(), "yyyy-MM-dd"))
                 .setTurnover(new FinanceStsDTO.TurnoverSts()
-                        .setTurnover(statistic.getPayAmount())
+                        .setTurnover(statistic.getPayAmount().add(statistic.getRechargeAmount()))
                         .setWechat(statistic.getWechatPayAmount())
                         .setAlipay(statistic.getAlipayPayAmount())
                         .setSelfScan(statistic.getMainScanPayAmount())
+                        .setBarScan(statistic.getBackScanPayAmount())
                         .setCash(statistic.getCashPayAmount())
                         .setRecharge(statistic.getRechargeAmount())
                         .setOwed(statistic.getCreditPayAmount())
@@ -58,13 +59,14 @@ public class FinanceStsServiceImpl implements FinanceStsService {
                         .setPointsDiscountAmount(statistic.getPointDiscountAmount())
                         .setOrderDiscount(statistic.getOrderPriceDiscountAmount()))
                 .setRefund(new FinanceStsDTO.RefundSts()
-                        .setRefundAmount(statistic.getRefundAmount())
+                        .setRefundAmount(statistic.getRefundAmount().add(statistic.getRechargeRefundAmount()))
                         .setOnlineRefundAmount(statistic.getOnlineRefundAmount())
                         .setCashRefundAmount(statistic.getCashRefundAmount())
+                        .setCreditRefundAmount(statistic.getCreditRefundAmount())
+                        .setMemberRefundAmount(statistic.getMemberRefundAmount())
                         .setRechargeRefundAmount(statistic.getRechargeRefundAmount())
                         .setOnlineRechargeRefundAmount(statistic.getOnlineRechargeRefundAmount())
-                        .setCashRechargeRefundAmount(statistic.getCashRechargeRefundAmount())
-                        .setMemberRefundAmount(statistic.getMemberRefundAmount()))
+                        .setCashRechargeRefundAmount(statistic.getCashRechargeRefundAmount()))
                 .setSts(new FinanceStsDTO.Sts()
                         .setCustomerCount(statistic.getCustomerCount())
                         .setOrderCount(statistic.getOrderCount())

cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoCustomServiceImpl.java

@@ -1050,6 +1050,7 @@ public class OrderInfoCustomServiceImpl implements OrderInfoCustomService {
         payment.setPayStatus(PayTypeConstants.PayStatus.FAIL);
         payment.setPlatformType(notifyRespDTO.getPlatform());
         payment.setChannel(channel);
+        payment.setPayTime(LocalDateTimeUtil.parse(notifyRespDTO.getPaySuccessTime(), "yyyy-MM-dd HH:mm:ss"));
         if ("TRADE_SUCCESS".equals(notifyRespDTO.getStatus())) {
             payment.setPayStatus(PayTypeConstants.PayStatus.SUCCESS);
             if (PayTypeConstants.SourceType.ORDER.equals(payment.getSourceType())) {
@@ -1196,6 +1197,13 @@ public class OrderInfoCustomServiceImpl implements OrderInfoCustomService {
         if (orderInfo.getCreditBuyerId() != null) {
             upOrderInfo.setCreditBuyerId(orderInfo.getCreditBuyerId());
         }
+        if (PayEnums.FREE_PAY.equals(payType)) {
+            if (orderInfo.getDiscountAllAmount() == null) {
+                upOrderInfo.setDiscountAllAmount(orderInfo.getOrderAmount());
+            } else {
+                upOrderInfo.setDiscountAllAmount(orderInfo.getDiscountAllAmount().add(orderInfo.getOrderAmount()));
+            }
+        }
         if (ObjectUtil.isNotNull(payType)) {
             upOrderInfo.setPayType(payType.getValue());
             orderInfo.setPayType(payType.getValue());

cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderPayServiceImpl.java

@@ -290,7 +290,7 @@ public class OrderPayServiceImpl implements OrderPayService {
         }
         String payOrderNo = orderInfo.getPlatformType() + CzgRandomUtils.snowflake();
         Long paymentId = payService.initPayment(OrderPayment.orderPay(payParam.getShopId(), orderInfo.getId(), payOrderNo, orderInfo.getOrderAmount(), ""));
-        upOrderPayInfo(orderInfo.getId(), PayCst.Type.ALIPAY.equals(payParam.getPayType()) ? PayEnums.ALIPAY_MINI : PayEnums.WECHAT_MINI, paymentId,
+        upOrderPayInfo(orderInfo.getId(), PayEnums.MAIN_SCAN, paymentId,
                 payParam.getCheckOrderPay() == null ? null : payParam.getCheckOrderPay().getRemark());
         return payService.pay(payParam.getShopId(), CzgPayEnum.JS_PAY,
                 CzgPayBaseReq.jsPayReq(payOrderNo, "扫码支付", orderInfo.getOrderAmount().multiply(PayService.MONEY_RATE).longValue(),
@@ -358,7 +358,7 @@ public class OrderPayServiceImpl implements OrderPayService {
             orderInfoCustomService.upOrderInfo(orderInfo, orderInfo.getOrderAmount(),
                     LocalDateTime.now(), paymentId, PayEnums.BACK_SCAN);
             // 事务成功提交后执行消息发送
-            String printParam = orderInfo.getId() + "_" + (!"after-pay".equals( orderInfo.getPayMode()) ? 1 : 0) + "_1";
+            String printParam = orderInfo.getId() + "_" + (!"after-pay".equals(orderInfo.getPayMode()) ? 1 : 0) + "_1";
             rabbitPublisher.sendOrderPrintMsg(printParam, orderInfo.getIsPrint() == 1, "事务环境打印");
         } else {
             upOrderPayInfo(orderInfo.getId(), PayEnums.BACK_SCAN, paymentId,
@@ -375,10 +375,7 @@ public class OrderPayServiceImpl implements OrderPayService {
         if (orderInfo.getStatus().equals(OrderStatusEnums.CANCELLED.getCode())) {
             throw new CzgException("订单已过期不可退单");
         }
-        boolean isFirstRefund = true;
-        if (orderInfo.getRefundAmount().compareTo(BigDecimal.ZERO) != 0) {
-            isFirstRefund = false;
-        }
+        boolean isFirstRefund = orderInfo.getRefundAmount().compareTo(BigDecimal.ZERO) == 0;
         ShopInfo shopInfo = shopInfoService.getById(orderInfo.getShopId());
         Map<String, BigDecimal> returnProMap = new HashMap<>();
         boolean isPay = true;
@@ -437,9 +434,8 @@ public class OrderPayServiceImpl implements OrderPayService {
                     returnProMap.put(Convert.toStr(orderDetail.getProductId()), refundDetail.getNum());
                 }
             }
-            long count = orderDetailService.queryChain()
-                    .eq(OrderDetail::getOrderId, orderInfo.getId())
-                    .ne(OrderDetail::getStatus, OrderStatusEnums.REFUND.getCode()).count();
+            long count = orderDetailService.count(QueryWrapper.create().eq(OrderDetail::getOrderId, orderInfo.getId())
+                    .ne(OrderDetail::getStatus, OrderStatusEnums.REFUND.getCode()));
             if (count > 0 && isPay) {
                 orderInfo.setStatus(OrderStatusEnums.PART_REFUND.getCode());
             } else if (isPay) {
@@ -447,10 +443,9 @@ public class OrderPayServiceImpl implements OrderPayService {
             }
         } else {
             orderInfo.setStatus(OrderStatusEnums.REFUND.getCode());
-            List<OrderDetail> orderDetails = orderDetailService.queryChain()
-                    .select(OrderDetail::getId, OrderDetail::getProductId, OrderDetail::getNum, OrderDetail::getReturnNum, OrderDetail::getPackAmount, OrderDetail::getReturnNum)
-                    .eq(OrderDetail::getOrderId, orderInfo.getId())
-                    .list();
+            List<OrderDetail> orderDetails = orderDetailService.list(
+                    QueryWrapper.create().select(OrderDetail::getId, OrderDetail::getProductId, OrderDetail::getNum, OrderDetail::getReturnNum, OrderDetail::getPackAmount, OrderDetail::getReturnNum)
+                            .eq(OrderDetail::getOrderId, orderInfo.getId()));
             for (OrderDetail orderDetail : orderDetails) {
                 if (isPay) {
                     if (orderDetail.getProductId() != null && orderDetail.getProductId() > 0) {
@@ -517,7 +512,7 @@ public class OrderPayServiceImpl implements OrderPayService {
                              @NonNull String refundReason, @NonNull BigDecimal refundAmount) {
         OrderPayment payment = paymentService.getById(payOrderId);
         AssertUtil.isNull(payment, "退款失败支付记录不存在");
-        Long refundId = payService.initPayment(OrderPayment.refund(shopId, orderId, PayTypeConstants.SourceType.ORDER,
+        Long refundId = payService.initPayment(OrderPayment.refund(payment.getChannel(), shopId, orderId, PayTypeConstants.SourceType.ORDER,
                 refPayOrderNo, refundAmount, payment.getId(), payment.getPlatformType()));
 
         CzgResult<RefundRespDTO> refund = payService.refund(shopId, new CzgRefundReq(refPayOrderNo, refundReason, refundAmount.multiply(PayService.MONEY_RATE).longValue(),
@@ -529,6 +524,7 @@ public class OrderPayServiceImpl implements OrderPayService {
             throw new CzgException(refund.getMsg());
         } else {
             OrderPayment upPayment = new OrderPayment();
+            upPayment.setPayStatus(PayTypeConstants.PayStatus.SUCCESS);
             upPayment.setPayTime(LocalDateTimeUtil.parse(refund.getData().getRefundTime()));
             upPayment.setTradeNumber(refund.getData().getThirdRefundNo());
             upPayment.setRespJson(refund.getData().getOriginalData());

cash-service/order-service/src/main/java/com/czg/service/order/service/impl/PayServiceImpl.java

@@ -108,7 +108,7 @@ public class PayServiceImpl implements PayService {
                             @NonNull String refundReason, @NonNull BigDecimal refundAmount) {
         OrderPayment payment = paymentService.getById(payOrderId);
         AssertUtil.isNull(payment, "退款失败,支付记录不存在");
-        Long refundId = initPayment(OrderPayment.refund(shopId, sourceId, payment.getSourceType(), refPayOrderNo, refundAmount, payment.getId(), payment.getPlatformType()));
+        Long refundId = initPayment(OrderPayment.refund(payment.getChannel(), shopId, sourceId, payment.getSourceType(), refPayOrderNo, refundAmount, payment.getId(), payment.getPlatformType()));
         CzgResult<RefundRespDTO> refund = refund(shopId, new CzgRefundReq(refPayOrderNo, refundReason, refundAmount.multiply(MONEY_RATE).longValue(),
                 payment.getAmount().multiply(PayService.MONEY_RATE).longValue(), payment.getOrderNo(), "", payment.getPlatformType()));
         OrderPayment uOrderPayment = new OrderPayment();

cash-service/order-service/src/main/java/com/czg/service/order/service/impl/ShopOrderStatisticServiceImpl.java

@@ -70,7 +70,7 @@ public class ShopOrderStatisticServiceImpl extends ServiceImpl<ShopOrderStatisti
         }
         if (day <= 1) {
             return List.of(onlineDataAmount);
-        }else {
+        } else {
             startDate = currentDate.minusDays(day - 1);
         }
         List<TotalVo> statDateRange = mapper.getStatDateRange(shopId, startDate, currentDate);
@@ -84,7 +84,7 @@ public class ShopOrderStatisticServiceImpl extends ServiceImpl<ShopOrderStatisti
         if (day <= 1) {
             Map<String, BigDecimal> onlinePayTypeDate = mapper.getOnlinePayTypeDate(shopId, currentDate);
             return CountPayTypeVo.realTimeDataByDay(onlinePayTypeDate);
-        }else {
+        } else {
             startDate = currentDate.minusDays(day - 1);
         }
         return CountPayTypeVo.mergePayTypeData(
@@ -104,7 +104,7 @@ public class ShopOrderStatisticServiceImpl extends ServiceImpl<ShopOrderStatisti
         }
         if (day <= 1) {
             return List.of(onlineProfitRateBarChart);
-        }else {
+        } else {
             startDate = currentDate.minusDays(day - 1);
         }
         List<ProfitRateVO> statDateRange = mapper.profitRateBarChart(shopId, startDate, currentDate);
@@ -180,10 +180,11 @@ public class ShopOrderStatisticServiceImpl extends ServiceImpl<ShopOrderStatisti
         result.setTableCount(Optional.ofNullable(tableCount).orElse(0L));
         result.setProductCostAmount(Optional.ofNullable(productCostAmount).orElse(BigDecimal.ZERO));
 
-        //会员充值退款 充值退款金额（线上退款+现金退款）
+        //会员充值金额（线上充值+现金充值+霸王餐充值）
         BigDecimal cashRechargeAmount = Objects.requireNonNullElse(result.getCashRechargeAmount(), BigDecimal.ZERO);
         BigDecimal onlineRechargeAmount = Objects.requireNonNullElse(result.getOnlineRechargeAmount(), BigDecimal.ZERO);
-        BigDecimal rechargeAmount = cashRechargeAmount.add(onlineRechargeAmount);
+        BigDecimal freeRechargeAmount = Objects.requireNonNullElse(onlineStat != null ? onlineStat.getBackDiscountAmount() : null, BigDecimal.ZERO);
+        BigDecimal rechargeAmount = cashRechargeAmount.add(onlineRechargeAmount).add(freeRechargeAmount);
         result.setRechargeAmount(rechargeAmount);
         //会员充值退款 充值退款金额（线上退款+现金退款）
         BigDecimal onlineRechargeRefundAmount = Objects.requireNonNullElse(
@@ -220,9 +221,6 @@ public class ShopOrderStatisticServiceImpl extends ServiceImpl<ShopOrderStatisti
                 .add(creditPayAmount);
         result.setPayAmount(totalPayAmount);
         calculateShopOrderStatistic(result);
-        calculateProfitInfo(result);
-        calculateTurnoverRate(result);
-        calculateAvgPayAmount(result);
         return result;
     }
 

cash-service/order-service/src/main/java/com/czg/service/order/service/impl/ShopUserServiceImpl.java

@@ -314,7 +314,7 @@ public class ShopUserServiceImpl implements ShopUserPayService {
                 return CzgResult.failure("退款失败,该充值记录不存在");
             }
             String refPayOrderNo = "REFVIP" + IdUtil.getSnowflakeNextId();
-            refPaymentId = payService.initPayment(OrderPayment.refund(refPayParam.getShopId(), shopUser.getId(), PayTypeConstants.SourceType.MEMBER_IN,
+            refPaymentId = payService.initPayment(OrderPayment.refund(payment.getChannel(), refPayParam.getShopId(), shopUser.getId(), PayTypeConstants.SourceType.MEMBER_IN,
                     refPayOrderNo, refPayParam.getRefAmount(), inFlow.getId(), payment.getPlatformType()));
             CzgResult<RefundRespDTO> refund = payService.refund(refPayParam.getShopId(), new CzgRefundReq(refPayOrderNo, refPayParam.getRemark(),
                     refPayParam.getRefAmount().multiply(PayService.MONEY_RATE).longValue(), payment.getAmount().multiply(PayService.MONEY_RATE).longValue(),