From 855921d253a4854d4fb78b83bfcf7c6e93b3f68d Mon Sep 17 00:00:00 2001 From: mitao <2763622819@qq.com> Date: 星期三, 29 五月 2024 19:43:50 +0800 Subject: [PATCH] 1.提交【管理后台】团购、拍卖商品立即结束退款处理 2.提交【管理后台】拍卖场管理部分接口 --- ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/PaylogServiceImpl.java | 89 ++++++++++++++++++++++++++++++++++++-------- 1 files changed, 73 insertions(+), 16 deletions(-) diff --git a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/PaylogServiceImpl.java b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/PaylogServiceImpl.java index a76532a..24d6073 100644 --- a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/PaylogServiceImpl.java +++ b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/PaylogServiceImpl.java @@ -1,14 +1,18 @@ package com.ruoyi.order.service.impl; +import static com.ruoyi.order.util.tencent.WXPay.requestRefundService; +import static com.ruoyi.order.util.tencent.WXPay.requestUnifiedorderService; + import com.alipay.api.AlipayClient; import com.alipay.api.DefaultAlipayClient; import com.alipay.api.request.AlipayTradeRefundRequest; import com.alipay.api.response.AlipayTradeRefundResponse; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.common.core.domain.R; +import com.ruoyi.common.core.utils.StringUtils; import com.ruoyi.order.domain.pojo.Paylog; import com.ruoyi.order.mapper.PaylogMapper; import com.ruoyi.order.service.IPaylogService; -import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.order.util.SinataUtil; import com.ruoyi.order.util.alipay.config.AlipayConfig; import com.ruoyi.order.util.alipay.util.PayDemoActivity; @@ -17,24 +21,26 @@ import com.ruoyi.order.util.tencent.common.XMLParser; import com.ruoyi.order.util.tencent.protocol.AppPayReqData; import com.ruoyi.order.util.tencent.protocol.UnifiedorderReqData; -import org.springframework.stereotype.Service; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.ResponseBody; - +import com.ruoyi.system.api.domain.dto.RefundDTO; +import java.io.IOException; +import java.io.PrintWriter; +import java.math.BigDecimal; +import java.time.LocalDateTime; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.Iterator; +import java.util.List; +import java.util.Map; +import java.util.Optional; +import java.util.Set; +import java.util.function.Function; +import java.util.regex.Matcher; +import java.util.regex.Pattern; +import java.util.stream.Collectors; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; -import java.io.IOException; -import java.io.PrintWriter; -import java.time.LocalDateTime; -import java.util.HashMap; -import java.util.Iterator; -import java.util.Map; -import java.util.regex.Matcher; -import java.util.regex.Pattern; - -import static com.ruoyi.order.util.tencent.WXPay.requestRefundService; -import static com.ruoyi.order.util.tencent.WXPay.requestUnifiedorderService; +import org.springframework.stereotype.Service; /** * <p> @@ -431,4 +437,55 @@ return m.matches(); } + @Override + public Map<String, Object> refund(List<RefundDTO> refundDTOS) { + Map<String, Object> map = new HashMap<>(); + Set<String> orderNoList = refundDTOS.stream().map(RefundDTO::getOrderNo) + .collect(Collectors.toSet()); + if (StringUtils.isNotEmpty(orderNoList)) { + Map<String, Paylog> paylogMap = iPaylogService.lambdaQuery() + .in(Paylog::getOutTradeNo, orderNoList).eq(Paylog::getState, 1).list().stream() + .collect(Collectors.toMap(Paylog::getOutTradeNo, Function.identity())); + List<Paylog> updList = new ArrayList<>(); + for (RefundDTO refundDTO : refundDTOS) { + String orderNo = refundDTO.getOrderNo(); + BigDecimal amount = refundDTO.getAmount(); + Paylog paylog = paylogMap.get(orderNo); + Optional.of(paylog).ifPresent(pay -> { + Boolean res = handleRefund(pay, amount, orderNo); + map.put(orderNo, res); + if (res) { + pay.setState(3); + updList.add(pay); + } + }); + } + iPaylogService.updateBatchById(updList); + } + return map; + } + + private Boolean handleRefund(Paylog paylog, BigDecimal amount, + String orderNo) { + boolean res = false; + if (StringUtils.isNotNull(paylog)) { + if (paylog.getPayType() == 1) { + res = paylogServiceImpl.refundForAlipay(paylog.getOutTradeNo(), + paylog.getTradeNo(), amount.doubleValue()); + } + if (paylog.getPayType() == 2) { + String refundMoney = SinataUtil.doubleRetainTwo( + amount.doubleValue() * 100d); + Integer refundFee = Integer.parseInt( + refundMoney.substring(0, refundMoney.length() - 3)); + String money = SinataUtil.doubleRetainTwo(paylog.getPayMoney() * 100d); + Integer totalFee = Integer.parseInt( + money.substring(0, money.length() - 3)); + res = paylogServiceImpl.refundForWxpay(2, paylog.getTradeNo(), + paylog.getOutTradeNo(), orderNo, totalFee, + refundFee, "4"); + } + } + return res; + } } -- Gitblit v1.7.1