feat get redirectUrl

dengwei
1 parent a213767f
Showing 11 changed files with 281 additions and 10 deletions
cashier-mall/src/main/java/com/diligrp/cashier/mall/api/ManualHandlerApi.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/co/AuthLoginCO.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/model/MallBizPayment.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/biz/PayNotifyService.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/biz/impl/MallBizOrderServiceImpl.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/biz/impl/MallBizRefundServiceImpl.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/biz/impl/PayNotifyServiceImpl.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/sourcechannel/AbstractSourceChannel.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/sourcechannel/RtMallChannel.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/sourcechannel/SamMallChannel.java
scripts/dili-cashier-mall.sql
@@ -5,8 +5,8 @@ import com.diligrp.cashier.mall.dao.MallBizRefundDao;
 import com.diligrp.cashier.mall.model.MallBizPayment;
 import com.diligrp.cashier.mall.model.MallBizRefund;
 import com.diligrp.cashier.mall.service.biz.MallBizPaymentService;
+import com.diligrp.cashier.mall.service.biz.PayNotifyService;
 import com.diligrp.cashier.shared.domain.Message;
-import com.diligrp.cashier.shared.spi.IPaymentEventListener;
 import com.diligrp.cashier.shared.spi.domain.PaymentResultBO;
 import com.diligrp.cashier.shared.spi.domain.RefundResultBO;
 import jakarta.annotation.Resource;
@@ -24,7 +24,7 @@ import org.springframework.web.bind.annotation.*;
 @Validated
 public class ManualHandlerApi {
     @Resource
-    private IPaymentEventListener payNotifyServiceImpl;
+    private PayNotifyService payNotifyServiceImpl;
     @Resource
     private MallBizPaymentService mallBizPaymentService;
     @Resource
@@ -58,4 +58,8 @@ public class ManualHandlerApi {
         return Message.success();
     }
+    @GetMapping("/refund/event")
+    public Message<?> handlePaymentEvent(String tradeId) {
+        return Message.success(payNotifyServiceImpl.redirectUrl(tradeId));
+    }
 }
@@ -70,6 +70,11 @@ public class AuthLoginCO {
      */
     private String latitude;
+    /**
+     * 登录凭证
+     */
+    private String token;
+
     public String getLatitude() {
         return latitude;
     }
@@ -149,4 +154,12 @@ public class AuthLoginCO {
     public void setUsername(String username) {
         this.username = username;
     }
+
+    public String getToken() {
+        return token;
+    }
+
+    public void setToken(String token) {
+        this.token = token;
+    }
 }
@@ -165,10 +165,10 @@ public class MallBizPayment extends BaseDO {
         RtMallDynamicProperty.AppSecretDynamicProperty property = rtMallDynamicProperty.getBySourceAndType(mallBizOrder.getFirst().getSource(), mallBizOrder.getFirst().getOrderType());
         mallBizPayment.setPaymentCallback(property.getCallbackDomain());
-        // 大润发只支持一个订单单独结算 后期如何支持多订单组合支付
-        if (Objects.equals(mallBizOrder.getFirst().getOrderType(), OrderType.MINI_PROGRAM.code)) {
-            mallBizPayment.setCashierResultUrl(String.format(property.getCashierResultUrl(), mallBizOrder.getFirst().getOrderId()));
-        }
+        // 大润发只支持一个订单单独结算 后期如何支持多订单组合支付 修改为支付成功返回
+        // if (Objects.equals(mallBizOrder.getFirst().getOrderType(), OrderType.MINI_PROGRAM.code)) {
+        //     mallBizPayment.setCashierResultUrl(String.format(property.getCashierResultUrl(), mallBizOrder.getFirst().getOrderId()));
+        // }
         // 完善mall_biz_payment_order
         List<MallBizPaymentOrder> bizPaymentOrders = mallBizOrder.stream()
@@ -9,4 +9,5 @@ import com.diligrp.cashier.shared.spi.IPaymentEventListener;
  * @Description PayNotifyService
  */
 public interface PayNotifyService extends IPaymentEventListener {
+    String redirectUrl(String tradeId);
 }
@@ -266,6 +266,7 @@ public class MallBizOrderServiceImpl implements MallBizOrderService {
         );
         cashierOrderBO.setDescription(cashierOrderBO.getGoods());
         cashierOrderBO.setAttach(cashierOrderBO.getGoods());
+        LOG.info("submitOrder param: {}", JsonUtils.toJsonString(cashierOrderBO));
         PaymentUrlBO paymentUrlBO = cashierDeskManager.submitOrder(cashierOrderBO);
         Optional.ofNullable(paymentUrlBO).ifPresent(vo -> {
             mallBizPayment.setCashierUrl(vo.paymentUrl());
@@ -121,6 +121,7 @@ public class MallBizRefundServiceImpl implements MallBizRefundService {
      */
     private RefundResultBO doRefund(MallBizRefund refund) {
         CashierRefundBO cashierRefundBO = new CashierRefundBO(refund.getPayTradeId(), refund.getRefundFee(), null, "用户主动取消！");
+        LOG.info("doRefund cashierRefundBO: {}", JsonUtils.toJsonString(cashierRefundBO));
         RefundResultBO refundResultBO = cashierDeskManager.doRefund(cashierRefundBO);
         refund.setRefundTradeId(refundResultBO.getRefundId());
         return refundResultBO;
@@ -73,4 +73,17 @@ public class PayNotifyServiceImpl implements PayNotifyService {
         MallBizOrder mallBizOrder = mallBizOrderService.getById(mallBizRefund.getBizOrderId());
         MallInitializeContext.getBySource(mallBizOrder.getSource()).refundOnEvent(event, mallBizRefund);
     }
+
+    /**
+     * redirectUrl
+     */
+    @Override
+    public String redirectUrl(String tradeId) {
+        MallBizPayment mallBizPayment = mallBizPaymentService.getByPayTradeId(tradeId);
+
+        Long bizOrderId = Long.valueOf(mallBizPayment.getBizOrderId().split(",")[0]);
+        MallBizOrder mallBizOrder = mallBizOrderService.getById(bizOrderId);
+
+        return MallInitializeContext.getBySource(mallBizOrder.getSource()).redirectUrl(mallBizPayment);
+    }
 }
@@ -5,6 +5,8 @@ import com.diligrp.cashier.mall.MallConstants;
 import com.diligrp.cashier.mall.dao.MallBizOrderDao;
 import com.diligrp.cashier.mall.domain.rtmall.co.AuthLoginCO;
 import com.diligrp.cashier.mall.domain.rtmall.vo.UserInfoVO;
+import com.diligrp.cashier.mall.exception.RtMartMallException;
+import com.diligrp.cashier.mall.model.MallBizOrder;
 import com.diligrp.cashier.mall.model.MallBizPayment;
 import com.diligrp.cashier.mall.model.MallBizPaymentOrder;
 import com.diligrp.cashier.mall.model.MallBizRefund;
@@ -12,6 +14,8 @@ import com.diligrp.cashier.mall.property.RtMallDynamicProperty;
 import com.diligrp.cashier.mall.service.biz.MallBizPaymentService;
 import com.diligrp.cashier.mall.service.biz.MallBizRefundService;
 import com.diligrp.cashier.mall.type.OrderState;
+import com.diligrp.cashier.mall.type.OrderType;
+import com.diligrp.cashier.mall.type.RtMarkErrorCode;
 import com.diligrp.cashier.pipeline.type.PaymentState;
 import com.diligrp.cashier.shared.spi.domain.PaymentResultBO;
 import com.diligrp.cashier.shared.spi.domain.RefundResultBO;
@@ -117,6 +121,10 @@ public abstract class AbstractSourceChannel {
     public void refundOnEvent(RefundResultBO event, MallBizRefund mallBizRefund) {
         LOG.info("refundOnEvent event: {} mallBizRefund: {}", JsonUtils.toJsonString(event), JsonUtils.toJsonString(mallBizRefund));
+        // update mall_biz_refund
+        mallBizRefund.payCallBack(event);
+        mallBizRefundService.updateByPay(mallBizRefund);
+
         // check all refund state
         List<MallBizPaymentOrder> paymentOrderList = mallBizPaymentService.listPaymentOrderByBizOrderId(mallBizRefund.getBizOrderId());
         boolean success = paymentOrderList.stream().allMatch(vo -> Objects.equals(vo.getPayState(), PaymentState.SUCCESS.getCode()));
@@ -128,10 +136,6 @@ public abstract class AbstractSourceChannel {
             }
         }
-        // update mall_biz_refund
-        mallBizRefund.payCallBack(event);
-        mallBizRefundService.updateByPay(mallBizRefund);
-
         // notify other channel
         refundCallBack(event, mallBizRefund);
     }
@@ -144,11 +148,41 @@ public abstract class AbstractSourceChannel {
         List<MallBizPaymentOrder> paymentOrderList = mallBizPaymentService.listPaymentOrderByBizOrderIds(bizOrderIds);
         boolean success = paymentOrderList.stream().allMatch(vo -> Objects.equals(vo.getPayState(), PaymentState.SUCCESS.getCode()));
         if (success) {
+            LOG.info("订单全部支付完成，orderIds:{}", bizOrderIds);
             mallBizOrderDao.updateByIds(bizOrderIds, OrderState.PAYED.code);
         }
     }
     /**
+     * redirectUrl
+     */
+    public String redirectUrl(MallBizPayment mallBizPayment) {
+        Long bizOrderId = Long.valueOf(mallBizPayment.getBizOrderId().split(",")[0]);
+        MallBizOrder mallBizOrder = mallBizOrderDao.selectByPrimaryKey(bizOrderId);
+        if (Objects.isNull(mallBizOrder)) {
+            throw new RtMartMallException(RtMarkErrorCode.E5004);
+        }
+
+        String redirectUrl = redirectUrl(mallBizOrder, mallBizPayment);
+        LOG.info("redirectUrl: {}", redirectUrl);
+        return redirectUrl;
+    }
+
+    /**
+     * getAuthLogin from db
+     * userCode = userCode + "_" + channel + "_" + orderType
+     */
+    public AuthLoginCO getAuthLogin(String userCode, String channel, Integer orderType) {
+        Object cache = redisTemplate.opsForValue().get(MallConstants.MALL_USER_INFO + userCode + "_" + channel + "_" + orderType);
+        if (Objects.isNull(cache)) {
+            throw new RtMartMallException(RtMarkErrorCode.E5001);
+        }
+        AuthLoginCO authLogin = JsonUtils.fromJsonString(Objects.requireNonNull(cache).toString(), AuthLoginCO.class);
+        LOG.info("get auth login info: {}", JsonUtils.toJsonString(authLogin));
+        return authLogin;
+    }
+
+    /**
      * 渠道
      */
     public abstract Integer source();
@@ -174,6 +208,11 @@ public abstract class AbstractSourceChannel {
     public abstract void refundCallBack(RefundResultBO event, MallBizRefund mallBizRefund);
     /**
+     * redirectUrl
+     */
+    public abstract String redirectUrl(MallBizOrder mallBizOrder, MallBizPayment mallBizPayment);
+
+    /**
      * sendDelayMessage
      */
     protected void sendDelayMessage(String load) {
@@ -23,6 +23,7 @@ import com.diligrp.cashier.shared.util.UrlParamParserUtils;
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.google.common.collect.Maps;
 import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Component;
@@ -48,6 +49,7 @@ public class RtMallChannel extends AbstractSourceChannel {
         RtMallDynamicProperty.AppSecretDynamicProperty property = rtMallDynamicProperty.getBySourceAndType(authLogin.getSource(), authLogin.getOrderType());
         LOG.info("authUrl property: {}", JsonUtils.toJsonString(property));
         authLogin.setMchId(property.getMchId());
+        authLogin.setToken(token);
         // 替换参数
         String authUrl = property.getAuthUrl();
@@ -160,6 +162,35 @@ public class RtMallChannel extends AbstractSourceChannel {
     }
     /**
+     * redirectUrl
+     */
+    @Override
+    public String redirectUrl(final MallBizOrder mallBizOrder,
+                              final MallBizPayment mallBizPayment) {
+        RtMallDynamicProperty.AppSecretDynamicProperty property = rtMallDynamicProperty.getBySourceAndType(mallBizOrder.getSource(), mallBizOrder.getOrderType());
+        String cashierResultUrl = property.getCashierResultUrl();
+        if (StringUtils.isBlank(cashierResultUrl)) {
+            return null;
+        }
+
+        long timestamp = DateUtils.timestampInSeconds();
+        // 换取token
+        AuthLoginCO authLogin = getAuthLogin(mallBizOrder.getUserCode(), mallBizOrder.getChannel(), mallBizOrder.getOrderType());
+        cashierResultUrl = String.format(cashierResultUrl, authLogin.getToken(), timestamp, mallBizOrder.getOrderId());
+        LOG.info("cashierResultUrl: {}", cashierResultUrl);
+
+        // 获取参数
+        Map<String, String> queryParams = UrlParamParserUtils.parseQueryParams(cashierResultUrl);
+        LOG.info("cashierResultUrl queryParams: {}", JsonUtils.toJsonString(queryParams));
+
+        // 验签
+        String sign = RtMallSignMd5Utils.generateSign(queryParams, property.getAppSecret());
+        LOG.info("cashierResultUrl sign: {}", sign);
+        cashierResultUrl = cashierResultUrl.concat("&sign=").concat(sign);
+        return cashierResultUrl;
+    }
+
+    /**
      * getProperty
      */
     private RtMallDynamicProperty.AppSecretDynamicProperty getProperty(MallBizOrder mallBizOrder) {
@@ -2,6 +2,7 @@ package com.diligrp.cashier.mall.service.sourcechannel;
 import com.diligrp.cashier.mall.domain.rtmall.co.AuthLoginCO;
 import com.diligrp.cashier.mall.domain.rtmall.vo.UserInfoVO;
+import com.diligrp.cashier.mall.model.MallBizOrder;
 import com.diligrp.cashier.mall.model.MallBizPayment;
 import com.diligrp.cashier.mall.model.MallBizRefund;
 import com.diligrp.cashier.mall.property.RtMallDynamicProperty;
@@ -43,6 +44,11 @@ public class SamMallChannel extends AbstractSourceChannel {
     }
     @Override
+    public String redirectUrl(MallBizOrder mallBizOrder, MallBizPayment mallBizPayment) {
+        return "";
+    }
+
+    @Override
     public Integer source() {
         return 20;
     }
+# 订单数据
+CREATE TABLE `mall_biz_order` (
+    `id` bigint unsigned NOT NULL,
+    `order_no` varchar(50) NOT NULL COMMENT '订单单号-系统生成',
+    `order_id` varchar(64) NOT NULL COMMENT '业务侧订单号',
+    `trade_id` varchar(64) DEFAULT NULL COMMENT '业务侧支付单号',
+    `channel` varchar(20) NOT NULL COMMENT 'dili侧渠道(中瑞 地利)',
+    `firm_id` bigint DEFAULT NULL COMMENT '市场id',
+    `mch_id` varchar(20) DEFAULT NULL COMMENT 'dili商户code',
+    `source` tinyint unsigned NOT NULL COMMENT '订单来源(10大润发 2山姆)-换取回调地址',
+    `order_type` tinyint NOT NULL DEFAULT '3' COMMENT '支付单类型: 1线下扫码购，2 接口扫码购，3小程序',
+    `user_code` varchar(64) NOT NULL COMMENT '用户编号',
+    `username` varchar(64) NOT NULL COMMENT '用户名称',
+    `company_code` varchar(64) DEFAULT NULL COMMENT '企业组编号',
+    `shop_code` varchar(32) DEFAULT NULL COMMENT '门店编号',
+    `shop_name` varchar(100) DEFAULT NULL COMMENT '门店名称',
+    `total_amount` bigint unsigned NOT NULL COMMENT '总金额分',
+    `freight_fee` bigint unsigned DEFAULT NULL COMMENT '运费分',
+    `discount_fee` bigint DEFAULT NULL COMMENT '优惠金额, 单位：分',
+    `state` tinyint unsigned NOT NULL DEFAULT '0' COMMENT '订单状态(0-notpay-未支付 1-payed-已支付 2-notpaycancel-已取消 3-payedcancel-已退款 4-done-订单完成 5-buyer_confirm-待用户收货)',
+    `rtmart_state` tinyint DEFAULT NULL COMMENT '配送状态(1-transfer-转单 2-package-打包 3-collect-揽件 4-delivery-配达)',
+    `order_time` datetime NOT NULL COMMENT '下单时间',
+    `order_expire` int DEFAULT '10' COMMENT '订单有效期分钟-超时自动取消',
+    `version` int unsigned NOT NULL DEFAULT '1' COMMENT '版本号',
+    `created_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    `modifier_name` varchar(50) DEFAULT NULL COMMENT '修改人',
+    `modified_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+    `deleted` tinyint unsigned NOT NULL DEFAULT '0' COMMENT '是否删除0未删',
+    PRIMARY KEY (`id`) USING BTREE,
+    UNIQUE KEY `unq_order_id` (`order_id`) USING BTREE,
+    KEY `idx_user_code` (`user_code`) USING BTREE,
+    KEY `idx_order_time` (`order_time`) USING BTREE
+) ENGINE=InnoDB COMMENT='业务-订单';
+
+CREATE TABLE `mall_biz_order_address` (
+    `id` bigint unsigned NOT NULL COMMENT '订单主单id',
+    `receiver_name` varchar(100) DEFAULT NULL COMMENT '接收名称',
+    `receiver_mobile` varchar(20) DEFAULT NULL COMMENT '接收电话',
+    `receiver_address` varchar(250) DEFAULT NULL COMMENT '接收地址',
+    PRIMARY KEY (`id`) USING BTREE
+) ENGINE=InnoDB COMMENT='业务-订单地址';
+
+CREATE TABLE `mall_biz_order_item` (
+    `id` bigint unsigned NOT NULL,
+    `biz_order_id` bigint NOT NULL COMMENT '订单主单id',
+    `sub_order_id` varchar(64) NOT NULL COMMENT '业务侧子订单号',
+    `order_id` varchar(64) NOT NULL COMMENT '业务侧订单号',
+    `trade_id` varchar(64) DEFAULT NULL COMMENT '业务侧支付单号',
+    `shop_code` varchar(32) DEFAULT NULL COMMENT '门店编号',
+    `shop_name` varchar(100) DEFAULT NULL COMMENT '门店名称',
+    `item_bn` varchar(100) NOT NULL COMMENT '商品SKU编号',
+    `item_name` varchar(255) NOT NULL COMMENT '商品名称',
+    `num` int unsigned NOT NULL COMMENT '数量',
+    `price` bigint NOT NULL COMMENT '单价分',
+    `amount` bigint NOT NULL COMMENT '小计金额分',
+    `discount_fee` bigint DEFAULT NULL COMMENT '优惠金额分',
+    `pic` varchar(500) DEFAULT NULL COMMENT '商品图片',
+    `tax_output_rate` varchar(10) DEFAULT NULL COMMENT '销项税率',
+    `tax_classification_code` varchar(50) DEFAULT NULL COMMENT '税则分类编码',
+    `tax_classification_name` varchar(100) DEFAULT NULL COMMENT '税则分类名称',
+    PRIMARY KEY (`id`) USING BTREE,
+    UNIQUE KEY `unq_sub_order_id` (`sub_order_id`,`trade_id`) USING BTREE,
+    KEY `idx_order_id` (`order_id`) USING BTREE,
+    KEY `idx_biz_order_id` (`biz_order_id`) USING BTREE
+) ENGINE=InnoDB COMMENT='业务-订单商品明细';
+
+CREATE TABLE `mall_biz_payment` (
+    `id` bigint unsigned NOT NULL,
+    `pay_trade_no` varchar(50) NOT NULL COMMENT '支付单号-系统生成',
+    `biz_order_id` varchar(250) NOT NULL COMMENT '订单id集合(mall_biz_order.id)',
+    `order_id` varchar(500) NOT NULL COMMENT '业务侧订单号(多个)',
+    `trade_id` varchar(500) NOT NULL COMMENT '业务侧支付单号(多个)',
+    `user_code` varchar(50) NOT NULL COMMENT '用户code',
+    `pay_trade_id` varchar(50) NOT NULL COMMENT 'dili交易流水号',
+    `firm_id` bigint DEFAULT NULL COMMENT '市场id',
+    `mch_id` varchar(20) NOT NULL COMMENT 'dili商户code',
+    `card_no` varchar(50) DEFAULT NULL COMMENT 'dili卡号',
+    `username` varchar(100) DEFAULT NULL COMMENT 'dili用户名',
+    `user_id` bigint DEFAULT NULL COMMENT 'dili用户id',
+    `account_id` bigint DEFAULT NULL COMMENT 'dili账户id',
+    `fund_account_id` bigint DEFAULT NULL COMMENT 'dili资金账户id',
+    `open_id` varchar(50) DEFAULT NULL COMMENT '第三方openId',
+    `pay_fee` bigint NOT NULL COMMENT '支付金额分',
+    `pay_state` tinyint unsigned NOT NULL DEFAULT '1' COMMENT '1:待支付 2:支付中 4:支付成功 6:支付失败',
+    `pay_time` datetime DEFAULT NULL COMMENT 'dili支付成功时间',
+    `channel_id` tinyint unsigned DEFAULT NULL COMMENT '支付渠道(微信 园区卡)',
+    `cashier_url` varchar(500) DEFAULT NULL COMMENT '收银台跳转链接-创建订单时返回',
+    `payment_callback` varchar(255) DEFAULT NULL COMMENT '支付成功回调业务侧接口',
+    `ext` varchar(1000) DEFAULT NULL COMMENT '扩展json',
+    `version` int unsigned NOT NULL DEFAULT '1' COMMENT '版本号',
+    `created_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    `modified_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '变更时间',
+    PRIMARY KEY (`id`) USING BTREE,
+    UNIQUE KEY `unq_pay_trade_no` (`pay_trade_no`) USING BTREE,
+    UNIQUE KEY `unq_pay_trade_id` (`pay_trade_id`) USING BTREE
+) ENGINE=InnoDB COMMENT='业务-结算(N订单:1)';
+
+
+CREATE TABLE `mall_biz_payment_order` (
+    `id` bigint unsigned NOT NULL,
+    `biz_payment_id` bigint NOT NULL COMMENT '结算id(mall_biz_paymen.id)',
+    `pay_trade_no` varchar(50) NOT NULL COMMENT '支付单号(mall_biz_paymen.pay_trade_no)',
+    `biz_order_id` bigint NOT NULL COMMENT '订单id(mall_biz_order.id)',
+    `order_id` varchar(64) NOT NULL COMMENT '业务侧订单号',
+    `trade_id` varchar(64) NOT NULL COMMENT '业务侧支付单号',
+    `pay_trade_id` varchar(50) NOT NULL COMMENT 'dili交易流水号(mall_biz_payment.pay_trade_id)',
+    `pay_fee` bigint NOT NULL COMMENT '支付金额分',
+    `pay_state` tinyint NOT NULL DEFAULT '1' COMMENT '1:待支付 2:支付中 4:支付成功 6:支付失败',
+    `pay_time` datetime DEFAULT NULL COMMENT 'dili支付成功时间',
+    PRIMARY KEY (`id`) USING BTREE,
+    UNIQUE KEY `unq_order_id` (`order_id`,`trade_id`) USING BTREE,
+    KEY `idx_biz_order_id` (`biz_order_id`) USING BTREE,
+    KEY `idx_pay_trade_id` (`pay_trade_id`) USING BTREE,
+    KEY `idx_pay_trade_no` (`pay_trade_no`) USING BTREE
+) ENGINE=InnoDB COMMENT='业务-结算订单(N:N)';
+
+CREATE TABLE `mall_biz_refund` (
+    `id` bigint unsigned NOT NULL AUTO_INCREMENT,
+    `biz_payment_id` bigint NOT NULL COMMENT '结算id(mall_biz_payment.id)',
+    `biz_order_id` bigint NOT NULL COMMENT '订单id(mall_biz_order.id)',
+    `refund_trade_no` varchar(50) NOT NULL COMMENT '退款单号-系统生成',
+    `refund_bn` varchar(64) DEFAULT NULL COMMENT '业务侧退款单号',
+    `order_id` varchar(64) NOT NULL COMMENT '业务侧订单号',
+    `trade_id` varchar(64) DEFAULT NULL COMMENT '业务侧流水号',
+    `firm_id` bigint DEFAULT NULL COMMENT '市场id',
+    `mch_id` varchar(20) NOT NULL COMMENT '商户id',
+    `pay_trade_no` varchar(50) DEFAULT NULL COMMENT '支付单号(mall_biz_payment.pay_trade_no)',
+    `refund_trade_id` varchar(50) NOT NULL COMMENT 'dili退款流水号',
+    `pay_trade_id` varchar(50) DEFAULT NULL COMMENT 'dili交易流水号(mall_biz_payment.pay_trade_id)',
+    `refund_card_no` varchar(255) DEFAULT NULL COMMENT 'dili卡号',
+    `refund_user_id` bigint DEFAULT NULL COMMENT 'dili用户id',
+    `refund_username` varchar(50) DEFAULT NULL COMMENT 'dili用户名称',
+    `refund_account_id` bigint DEFAULT NULL COMMENT 'dili账号id',
+    `refund_time` datetime DEFAULT NULL COMMENT 'dili退款成功时间',
+    `refund_fee` bigint NOT NULL COMMENT '退款金额分',
+    `freight_fee` bigint DEFAULT '0' COMMENT '退运费分',
+    `refund_state` tinyint unsigned NOT NULL DEFAULT '1' COMMENT '1:待支付 2:支付中 4:支付成功 6:支付失败',
+    `refund_reason` varchar(255) DEFAULT NULL COMMENT '退款原因',
+    `refund_callback` varchar(255) DEFAULT NULL COMMENT '退款成功回调业务侧接口',
+    `version` int unsigned NOT NULL DEFAULT '1' COMMENT '版本号',
+    `creater_name` varchar(50) NOT NULL COMMENT '申请人',
+    `created_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '退款申请时间',
+    `refuse_reason` varchar(500) DEFAULT NULL COMMENT '失败原因',
+    PRIMARY KEY (`id`) USING BTREE,
+    UNIQUE KEY `unq_refund_trade_id` (`refund_trade_id`) USING BTREE,
+    UNIQUE KEY `unq_refund_bn` (`refund_bn`) USING BTREE,
+    KEY `idx_order_id` (`order_id`) USING BTREE,
+    KEY `idx_refund_trarde_no` (`refund_trade_no`) USING BTREE
+) ENGINE=InnoDB COMMENT='业务-退款';
+
+CREATE TABLE `mall_biz_refund_item` (
+    `id` bigint unsigned NOT NULL AUTO_INCREMENT,
+    `biz_refund_id` bigint unsigned NOT NULL COMMENT '退款主单id',
+    `sub_order_id` bigint unsigned NOT NULL COMMENT '业务子订单ID',
+    `item_bn` varchar(100) DEFAULT NULL COMMENT '商品SKU编号',
+    `item_name` varchar(255) DEFAULT NULL COMMENT '商品名称',
+    `num` int unsigned DEFAULT NULL COMMENT '退货数量',
+    `refund_fee` bigint DEFAULT NULL COMMENT '退款金额分',
+    PRIMARY KEY (`id`) USING BTREE,
+    UNIQUE KEY `unq_sub_order_id` (`sub_order_id`) USING BTREE,
+    KEY `idx_biz_refund_id` (`biz_refund_id`) USING BTREE
+) ENGINE=InnoDB COMMENT='业务-退款商品明细';