package cn.lili.modules.payment.kit.params.impl; import cn.hutool.json.JSONUtil; import cn.lili.common.enums.ResultCode; import cn.lili.common.exception.ServiceException; import cn.lili.modules.order.order.entity.dos.Order; import cn.lili.modules.order.order.entity.dos.Trade; import cn.lili.modules.order.order.entity.enums.OrderStatusEnum; import cn.lili.modules.order.order.entity.enums.PayStatusEnum; import cn.lili.modules.order.order.service.OrderService; import cn.lili.modules.order.order.service.TradeService; import cn.lili.modules.payment.kit.dto.PayParam; import cn.lili.modules.payment.kit.dto.PaymentSuccessParams; import cn.lili.modules.payment.entity.enums.CashierEnum; import cn.lili.modules.payment.kit.params.CashierExecute; import cn.lili.modules.payment.kit.params.dto.CashierParam; import cn.lili.modules.system.entity.dto.BaseSetting; import cn.lili.modules.system.entity.enums.SettingEnum; import cn.lili.modules.system.service.SettingService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.List; import java.util.stream.Collectors; /** * 整笔交易信息获取 * * @author Chopper * @since 2021-01-25 20:00 */ @Slf4j @Component public class TradeCashier implements CashierExecute { /** * 交易 */ @Autowired private TradeService tradeService; /** * 订单 */ @Autowired private OrderService orderService; /** * 设置 */ @Autowired private SettingService settingService; @Override public CashierEnum cashierEnum() { return CashierEnum.TRADE; } @Override public CashierParam getPaymentParams(PayParam payParam) { if (payParam.getOrderType().equals(CashierEnum.TRADE.name())) { //准备返回的数据 CashierParam cashierParam = new CashierParam(); //订单信息获取 Trade trade = tradeService.getBySn(payParam.getSn()); List orders = orderService.getByTradeSn(payParam.getSn()); String orderSns = orders.stream().map(Order::getSn).collect(Collectors.joining(", ")); cashierParam.setOrderSns(orderSns); for (Order order : orders) { //如果订单已支付,则不能发器支付 if (order.getPayStatus().equals(PayStatusEnum.PAID.name())) { throw new ServiceException(ResultCode.PAY_DOUBLE_ERROR); } //如果订单状态不是待付款,则抛出异常 if (!order.getOrderStatus().equals(OrderStatusEnum.UNPAID.name())) { throw new ServiceException(ResultCode.PAY_BAN); } } cashierParam.setPrice(trade.getFlowPrice()); try { BaseSetting baseSetting = JSONUtil.toBean(settingService.get(SettingEnum.BASE_SETTING.name()).getSettingValue(), BaseSetting.class); cashierParam.setTitle(baseSetting.getSiteName()); } catch (Exception e) { cashierParam.setTitle("多用户商城,在线支付"); } String subject = "在线支付"; cashierParam.setDetail(subject); cashierParam.setCreateTime(trade.getCreateTime()); return cashierParam; } return null; } @Override public void paymentSuccess(PaymentSuccessParams paymentSuccessParams) { if (paymentSuccessParams.getPayParam().getOrderType().equals(CashierEnum.TRADE.name())) { tradeService.payTrade(paymentSuccessParams.getPayParam().getSn(), paymentSuccessParams.getPaymentMethod(), paymentSuccessParams.getReceivableNo()); log.info("交易{}支付成功,方式{},流水号{},", paymentSuccessParams.getPayParam().getSn(), paymentSuccessParams.getPaymentMethod(), paymentSuccessParams.getReceivableNo()); } } @Override public Boolean paymentResult(PayParam payParam) { if (payParam.getOrderType().equals(CashierEnum.TRADE.name())) { Trade trade = tradeService.getBySn(payParam.getSn()); if (trade != null) { return PayStatusEnum.PAID.name().equals(trade.getPayStatus()); } else { throw new ServiceException(ResultCode.PAY_NOT_EXIST_ORDER); } } return false; } }