feat hourbuy init

dengwei
1 parent c2b3929b
Showing 36 changed files with 1173 additions and 81 deletions
cashier-mall/src/main/java/com/diligrp/cashier/mall/api/RtMallOrderApi.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/api/RtMallOrderRefundApi.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/context/MallInitializeContext.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/dao/MallBizOrderDao.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/dao/MallBizPaymentDao.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/dao/MallBizRefundDao.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/dao/MallBizRefundItemDao.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/co/OrderStatusCallbackCO.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/co/RefundCO.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/co/RefundItemCO.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/dto/package-info.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/vo/OrderPaymentVO.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/vo/OrderStatusCallbackVO.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/vo/RefundSuccessVO.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/model/MallBizOrder.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/model/MallBizPayment.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/model/MallBizRefund.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/biz/MallBizOrderService.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/biz/MallBizPaymentService.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/biz/MallBizRefundService.java
@@ -3,7 +3,9 @@ package com.diligrp.cashier.mall.api;
 import com.diligrp.cashier.mall.domain.rtmall.RtMarkMessage;
 import com.diligrp.cashier.mall.domain.rtmall.co.OrderCO;
 import com.diligrp.cashier.mall.domain.rtmall.co.OrderInfoCO;
+import com.diligrp.cashier.mall.domain.rtmall.co.OrderStatusCallbackCO;
 import com.diligrp.cashier.mall.domain.rtmall.vo.OrderPaymentVO;
+import com.diligrp.cashier.mall.domain.rtmall.vo.OrderStatusCallbackVO;
 import com.diligrp.cashier.mall.domain.rtmall.vo.OrderSuccessVO;
 import com.diligrp.cashier.mall.service.biz.MallBizOrderService;
 import com.diligrp.cashier.mall.sign.RtMallSign;
@@ -67,12 +69,15 @@ public class RtMallOrderApi {
     /**
      * statusCallback
      * @see https://shopex.yuque.com/hl0rrx/vlp0m4/nkwt5yrhdfzoy78s?singleDoc#oJ2JC
-     * 查询订单状态
+     * 订单状态回调
      */
     @PostMapping("/order/v1/status/callback")
     @ParamLogPrint(outPrint = true)
     @Sign(sign = RtMallSign.class)
-    public RtMarkMessage<?> statusCallback(@Valid @RequestBody Object req) {
-        return RtMarkMessage.success();
+    @RepeatSubmit(prefix = "status_callback:", value = "#req['order_id']", duplicationSubmit = SpelDuplicationSubmit.class)
+    public RtMarkMessage<OrderStatusCallbackVO> statusCallback(@Valid @RequestBody Object req) {
+        OrderStatusCallbackCO orderStatusCallback = JsonUtils.convertValue(req, OrderStatusCallbackCO.class);
+        RtMallValidateUtils.valid(orderStatusCallback);
+        return RtMarkMessage.success(mallBizOrderService.statusCallback(orderStatusCallback));
     }
 }
@@ -2,8 +2,9 @@ package com.diligrp.cashier.mall.api;
 import com.diligrp.cashier.mall.domain.rtmall.RtMarkMessage;
 import com.diligrp.cashier.mall.domain.rtmall.co.OrderCO;
-import com.diligrp.cashier.mall.domain.rtmall.vo.OrderSuccessVO;
-import com.diligrp.cashier.mall.service.biz.MallBizOrderService;
+import com.diligrp.cashier.mall.domain.rtmall.co.RefundCO;
+import com.diligrp.cashier.mall.domain.rtmall.vo.RefundSuccessVO;
+import com.diligrp.cashier.mall.service.biz.MallBizRefundService;
 import com.diligrp.cashier.mall.sign.RtMallSign;
 import com.diligrp.cashier.mall.util.RtMallValidateUtils;
 import com.diligrp.cashier.shared.annotation.ParamLogPrint;
@@ -30,27 +31,27 @@ import org.springframework.web.bind.annotation.RestController;
 @Validated
 public class RtMallOrderRefundApi {
     @Resource
-    private MallBizOrderService mallBizOrderService;
+    private MallBizRefundService mallBizRefundService;
     /**
-     * createOrder
+     * refund
      * @see https://shopex.yuque.com/hl0rrx/vlp0m4/nkwt5yrhdfzoy78s?singleDoc#oJ2JC
-     * 创建订单接口
+     * 申请退款接口
      */
     @PostMapping("/refund/v1")
     @ParamLogPrint(outPrint = true)
     @Sign(sign = RtMallSign.class)
-    @RepeatSubmit(prefix = "order_sync:", value = "#req['order_id']", duplicationSubmit = SpelDuplicationSubmit.class)
-    public RtMarkMessage<OrderSuccessVO> refund(@Valid @RequestBody Object req) {
-        OrderCO orderCo = JsonUtils.convertValue(req, OrderCO.class);
-        RtMallValidateUtils.valid(orderCo);
-        return RtMarkMessage.success(mallBizOrderService.createOrder(orderCo));
+    @RepeatSubmit(prefix = "refund:", value = "#req['order_id']", duplicationSubmit = SpelDuplicationSubmit.class)
+    public RtMarkMessage<RefundSuccessVO> refund(@Valid @RequestBody Object req) {
+        RefundCO refundCo = JsonUtils.convertValue(req, RefundCO.class);
+        RtMallValidateUtils.valid(refundCo);
+        return RtMarkMessage.success(mallBizRefundService.refund(refundCo));
     }
     /**
      * info
      * @see https://shopex.yuque.com/hl0rrx/vlp0m4/nkwt5yrhdfzoy78s?singleDoc#oJ2JC
-     * 查询订单状态
+     * 查询退款状态
      */
     @PostMapping("/refund/v1/info")
     @ParamLogPrint(outPrint = true)
@@ -2,7 +2,7 @@ package com.diligrp.cashier.mall.context;
 import com.diligrp.cashier.mall.exception.MallException;
 import com.diligrp.cashier.mall.service.paychannel.AbstractPayChannel;
-import com.diligrp.cashier.mall.service.sourcechannel.AbstractChannel;
+import com.diligrp.cashier.mall.service.sourcechannel.AbstractSourceChannel;
 import com.diligrp.cashier.shared.util.SpringContextUtils;
 import com.google.common.collect.Maps;
 import org.slf4j.Logger;
@@ -23,7 +23,7 @@ import java.util.Optional;
 @Component
 public class MallInitializeContext implements InitializingBean, DisposableBean {
     private static final Logger log = LoggerFactory.getLogger(MallInitializeContext.class);
-    public static Map<Integer, AbstractChannel> SOURCE_CHANNEL_MAP = Maps.newConcurrentMap();
+    public static Map<Integer, AbstractSourceChannel> SOURCE_CHANNEL_MAP = Maps.newConcurrentMap();
     public static Map<Integer, AbstractPayChannel> PAY_CHANNEL_MAP = Maps.newConcurrentMap();
     /**
@@ -31,7 +31,7 @@ public class MallInitializeContext implements InitializingBean, DisposableBean {
      */
     @Override
     public void afterPropertiesSet() throws Exception {
-        SpringContextUtils.getBeanOfTpe(AbstractChannel.class).forEach((key, value) -> {
+        SpringContextUtils.getBeanOfTpe(AbstractSourceChannel.class).forEach((key, value) -> {
             SOURCE_CHANNEL_MAP.put(value.source(), value);
         });
@@ -51,7 +51,7 @@ public class MallInitializeContext implements InitializingBean, DisposableBean {
     /**
      * getByType
      */
-    public static AbstractChannel getBySource(Integer source) {
+    public static AbstractSourceChannel getBySource(Integer source) {
         return Optional.ofNullable(SOURCE_CHANNEL_MAP.get(source)).orElseThrow(() -> new MallException("不支持该渠道！"));
     }
@@ -3,6 +3,7 @@ package com.diligrp.cashier.mall.dao;
 import com.diligrp.cashier.mall.model.MallBizOrder;
 import com.diligrp.cashier.shared.mybatis.MybatisMapperSupport;
+import org.apache.ibatis.annotations.Param;
 /**
  * MallBizOrderDao
@@ -21,4 +22,8 @@ public interface MallBizOrderDao extends MybatisMapperSupport {
     int updateByPrimaryKeySelective(MallBizOrder record);
     int updateByPrimaryKey(MallBizOrder record);
+
+    int update(MallBizOrder mallBizOrder);
+
+    MallBizOrder getByOrderId(@Param("orderId") String orderId);
 }
@@ -20,4 +20,6 @@ public interface MallBizPaymentDao extends MybatisMapperSupport {
     int updateByPrimaryKeySelective(MallBizPayment record);
     int updateByPrimaryKey(MallBizPayment record);
+
+    MallBizPayment getMallBizPayment(MallBizPayment mallBizPayment);
 }
+package com.diligrp.cashier.mall.dao;
+
+
+import com.diligrp.cashier.mall.model.MallBizRefund;
+import com.diligrp.cashier.shared.mybatis.MybatisMapperSupport;
+
+public interface MallBizRefundDao extends MybatisMapperSupport {
+    int deleteByPrimaryKey(Long id);
+
+    int insert(MallBizRefund record);
+
+    int insertSelective(MallBizRefund record);
+
+    MallBizRefund selectByPrimaryKey(Long id);
+
+    int updateByPrimaryKeySelective(MallBizRefund record);
+
+    int updateByPrimaryKey(MallBizRefund record);
+}
@@ -3,6 +3,9 @@ package com.diligrp.cashier.mall.dao;
 import com.diligrp.cashier.mall.model.MallBizRefundItem;
 import com.diligrp.cashier.shared.mybatis.MybatisMapperSupport;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
 /**
  * MallBizRefundItemDao
@@ -21,4 +24,6 @@ public interface MallBizRefundItemDao extends MybatisMapperSupport {
     int updateByPrimaryKeySelective(MallBizRefundItem record);
     int updateByPrimaryKey(MallBizRefundItem record);
+
+    void batchInsert(@Param("list") List<MallBizRefundItem> items);
 }
+package com.diligrp.cashier.mall.domain.rtmall.co;
+
+import com.diligrp.cashier.mall.domain.rtmall.RtMarkBaseCO;
+import jakarta.validation.constraints.NotBlank;
+
+/**
+ * @ClassName OrderStatusCallbackCO.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description OrderStatusCallbackCO
+ * 订单状态回调
+ */
+public class OrderStatusCallbackCO extends RtMarkBaseCO {
+    /**
+     * 订单ID
+     */
+    @NotBlank(message = "order_id is required")
+    private String orderId;
+
+    /**
+     * 会员编号
+     */
+    @NotBlank(message = "user_code is required")
+    private String userCode;
+
+    /**
+     * 公司编码
+     */
+    private String companyCode;
+
+    /**
+     * 订单状态
+     */
+    @NotBlank(message = "order_status is required")
+    private String orderStatus;
+
+    public String getOrderId() {
+        return orderId;
+    }
+
+    public void setOrderId(String orderId) {
+        this.orderId = orderId;
+    }
+
+    public String getUserCode() {
+        return userCode;
+    }
+
+    public void setUserCode(String userCode) {
+        this.userCode = userCode;
+    }
+
+    public String getCompanyCode() {
+        return companyCode;
+    }
+
+    public void setCompanyCode(String companyCode) {
+        this.companyCode = companyCode;
+    }
+
+    public String getOrderStatus() {
+        return orderStatus;
+    }
+
+    public void setOrderStatus(String orderStatus) {
+        this.orderStatus = orderStatus;
+    }
+}
+package com.diligrp.cashier.mall.domain.rtmall.co;
+
+import com.diligrp.cashier.mall.domain.rtmall.RtMarkBaseCO;
+import jakarta.validation.Valid;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+
+import java.util.List;
+
+/**
+ * @ClassName RefundCO.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description RefundCO
+ */
+public class RefundCO extends RtMarkBaseCO {
+    /**
+     * 订单ID
+     */
+    @NotBlank(message = "order id is required")
+    private String orderId;
+
+    /**
+     * 业务侧退款单号
+     */
+    @NotBlank(message = "refund bn is required")
+    private String refundBn;
+
+    /**
+     * 用户ID
+     */
+    @NotBlank(message = "user code is required")
+    private String userCode;
+
+    /**
+     * 退款金额
+     */
+    @NotNull(message = "refund fee is required")
+    private Long refundFee;
+
+    /**
+     * 公司ID
+     */
+    private String companyCode;
+
+    /**
+     * 退款商品列表
+     */
+    @Valid
+    private List<RefundItemCO> returnItemList;
+
+    public String getOrderId() {
+        return orderId;
+    }
+
+    public void setOrderId(String orderId) {
+        this.orderId = orderId;
+    }
+
+    public String getRefundBn() {
+        return refundBn;
+    }
+
+    public void setRefundBn(String refundBn) {
+        this.refundBn = refundBn;
+    }
+
+    public String getUserCode() {
+        return userCode;
+    }
+
+    public void setUserCode(String userCode) {
+        this.userCode = userCode;
+    }
+
+    public Long getRefundFee() {
+        return refundFee;
+    }
+
+    public void setRefundFee(Long refundFee) {
+        this.refundFee = refundFee;
+    }
+
+    public String getCompanyCode() {
+        return companyCode;
+    }
+
+    public void setCompanyCode(String companyCode) {
+        this.companyCode = companyCode;
+    }
+
+    public List<RefundItemCO> getReturnItemList() {
+        return returnItemList;
+    }
+
+    public void setReturnItemList(List<RefundItemCO> returnItemList) {
+        this.returnItemList = returnItemList;
+    }
+}
+package com.diligrp.cashier.mall.domain.rtmall.co;
+
+import com.fasterxml.jackson.databind.PropertyNamingStrategies;
+import com.fasterxml.jackson.databind.annotation.JsonNaming;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+
+/**
+ * @ClassName RefundItemCO.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description RefundItemCO
+ */
+@JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
+public class RefundItemCO {
+    @NotNull(message = "num is required")
+    private Integer num;
+
+    @NotNull(message = "refund_fee is required")
+    private Long refundFee;
+
+    @NotBlank(message = "item_bn is required")
+    private String itemBn;
+
+    @NotBlank(message = "item_name is required")
+    private String itemName;
+
+    @NotNull(message = "sub_order_id is required")
+    private Long subOrderId;
+
+    public Integer getNum() {
+        return num;
+    }
+
+    public void setNum(Integer num) {
+        this.num = num;
+    }
+
+    public Long getRefundFee() {
+        return refundFee;
+    }
+
+    public void setRefundFee(Long refundFee) {
+        this.refundFee = refundFee;
+    }
+
+    public String getItemBn() {
+        return itemBn;
+    }
+
+    public void setItemBn(String itemBn) {
+        this.itemBn = itemBn;
+    }
+
+    public String getItemName() {
+        return itemName;
+    }
+
+    public void setItemName(String itemName) {
+        this.itemName = itemName;
+    }
+
+    public Long getSubOrderId() {
+        return subOrderId;
+    }
+
+    public void setSubOrderId(Long subOrderId) {
+        this.subOrderId = subOrderId;
+    }
+}
+/**
+ * @ClassName package-info.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description TODO
+ * @date 2025-12-30 14:04
+ */
+package com.diligrp.cashier.mall.domain.rtmall.dto;
 package com.diligrp.cashier.mall.domain.rtmall.vo;
+import com.diligrp.cashier.shared.jackson.serialization.DateToSecondSerializer;
 import com.fasterxml.jackson.databind.PropertyNamingStrategies;
 import com.fasterxml.jackson.databind.annotation.JsonNaming;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+
+import java.time.LocalDateTime;
 /**
  * @ClassName OrderPaymentVO.java
@@ -20,17 +24,18 @@ public class OrderPaymentVO {
      * 支付状态, 0:待支付,1:支付成功
      * @see com.diligrp.cashier.mall.type.PayState
      */
-    private String payStatus;
+    private Integer payStatus;
     /**
      * 支付金额,单位分
      */
-    private String payFee;
+    private Long payFee;
     /**
      * 支付时间
      */
-    private Long payTime;
+    @JsonSerialize(using = DateToSecondSerializer.class)
+    private LocalDateTime payTime;
     /**
      * 支付流水号(可为空, 支付成功时必传)
@@ -45,30 +50,31 @@ public class OrderPaymentVO {
         this.outTradeNo = outTradeNo;
     }
-    public String getPayStatus() {
+    public Integer getPayStatus() {
         return payStatus;
     }
-    public void setPayStatus(String payStatus) {
+    public void setPayStatus(Integer payStatus) {
         this.payStatus = payStatus;
     }
-    public String getPayFee() {
+    public Long getPayFee() {
         return payFee;
     }
-    public void setPayFee(String payFee) {
+    public void setPayFee(Long payFee) {
         this.payFee = payFee;
     }
-    public Long getPayTime() {
+    public LocalDateTime getPayTime() {
         return payTime;
     }
-    public void setPayTime(Long payTime) {
+    public void setPayTime(LocalDateTime payTime) {
         this.payTime = payTime;
     }
+
     public String getTransactionId() {
         return transactionId;
     }
+package com.diligrp.cashier.mall.domain.rtmall.vo;
+
+import com.fasterxml.jackson.databind.PropertyNamingStrategies;
+import com.fasterxml.jackson.databind.annotation.JsonNaming;
+
+/**
+ * @ClassName OrderStatusCallbackVO.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description OrderStatusCallbackVO
+ */
+@JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
+public class OrderStatusCallbackVO {
+    /**
+     * 商户支付单号
+     */
+    private String outTradeNo;
+
+    public String getOutTradeNo() {
+        return outTradeNo;
+    }
+
+    public void setOutTradeNo(String outTradeNo) {
+        this.outTradeNo = outTradeNo;
+    }
+
+    public OrderStatusCallbackVO() {
+    }
+
+    public OrderStatusCallbackVO(String outTradeNo) {
+        this.outTradeNo = outTradeNo;
+    }
+}
+package com.diligrp.cashier.mall.domain.rtmall.vo;
+
+import com.fasterxml.jackson.databind.PropertyNamingStrategies;
+import com.fasterxml.jackson.databind.annotation.JsonNaming;
+
+/**
+ * @ClassName RefundSuccessVO.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description RefundSuccessVO
+ */
+@JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
+public class RefundSuccessVO {
+    private String outTradeNo;
+    private String outRefundNo;
+
+    public RefundSuccessVO() {
+    }
+
+    public RefundSuccessVO(String outTradeNo, String outRefundNo) {
+        this.outTradeNo = outTradeNo;
+        this.outRefundNo = outRefundNo;
+    }
+
+    public String getOutTradeNo() {
+        return outTradeNo;
+    }
+
+    public void setOutTradeNo(String outTradeNo) {
+        this.outTradeNo = outTradeNo;
+    }
+
+    public String getOutRefundNo() {
+        return outRefundNo;
+    }
+
+    public void setOutRefundNo(String outRefundNo) {
+        this.outRefundNo = outRefundNo;
+    }
+}
@@ -2,6 +2,7 @@ package com.diligrp.cashier.mall.model;
 import com.diligrp.cashier.mall.domain.rtmall.co.AuthLoginCO;
 import com.diligrp.cashier.mall.domain.rtmall.co.OrderCO;
+import com.diligrp.cashier.mall.domain.rtmall.co.OrderStatusCallbackCO;
 import com.diligrp.cashier.mall.type.OrderState;
 import com.diligrp.cashier.mall.type.RtmartState;
 import com.diligrp.cashier.mall.util.MallSnowflakeKeyManager;
@@ -118,6 +119,11 @@ public class MallBizOrder extends BaseDO {
     private Integer orderExpire;
     /**
+     * 修改人名称
+     */
+    private String modifierName;
+
+    /**
      * 订单地址信息
      */
     private MallBizOrderAddress mallBizOrderAddress;
@@ -268,6 +274,14 @@ public class MallBizOrder extends BaseDO {
         this.orderExpire = orderExpire;
     }
+    public String getModifierName() {
+        return modifierName;
+    }
+
+    public void setModifierName(String modifierName) {
+        this.modifierName = modifierName;
+    }
+
     public MallBizOrderAddress getMallBizOrderAddress() {
         return mallBizOrderAddress;
     }
@@ -327,4 +341,16 @@ public class MallBizOrder extends BaseDO {
                 });
         return mallBizOrder;
     }
+
+    /**
+     * ofUpdateState
+     */
+    public MallBizOrder ofUpdateState(OrderStatusCallbackCO orderStatusCallback) {
+        MallBizOrder update = new MallBizOrder();
+        update.setId(this.getId());
+        update.setState(OrderState.getCode(orderStatusCallback.getOrderStatus()));
+        update.setModifierName(orderStatusCallback.getUserCode());
+        update.setVersion(this.getVersion());
+        return update;
+    }
 }
 package com.diligrp.cashier.mall.model;
 import com.diligrp.cashier.mall.domain.rtmall.co.OrderCO;
+import com.diligrp.cashier.mall.domain.rtmall.vo.OrderPaymentVO;
 import com.diligrp.cashier.mall.property.MallDynamicProperty;
 import com.diligrp.cashier.mall.property.RtMallDynamicProperty;
 import com.diligrp.cashier.mall.type.PayState;
@@ -103,6 +104,14 @@ public class MallBizPayment extends BaseDO {
      */
     private String paymentCallback;
+    public MallBizPayment() {
+    }
+
+    public MallBizPayment(String orderId, String tradeId) {
+        this.orderId = orderId;
+        this.tradeId = tradeId;
+    }
+
     public static MallBizPayment of(final OrderCO orderCo,
                                     final MallBizOrder mallBizOrder) {
         MallSnowflakeKeyManager snowflakeKeyManager = SpringContextUtils.getBean(MallSnowflakeKeyManager.class);
@@ -114,11 +123,12 @@ public class MallBizPayment extends BaseDO {
         mallBizPayment.setOrderId(orderCo.getOrderId());
         mallBizPayment.setTradeId(orderCo.getTradeId());
         mallBizPayment.setPayFee(orderCo.getTotalAmount());
+        mallBizPayment.setMchId(mallBizOrder.getMchId());
         // TODO 2025/12/29: 支付信息
         mallBizPayment.setPayPaymentId("6666666666");
         String cashierUrl = SpringContextUtils.getBean(MallDynamicProperty.class).getUrl();
-        mallBizPayment.setCashierUrl(cashierUrl.concat("?payTradeNo=").concat(mallBizPayment.getPayTradeNo()));
+        mallBizPayment.setCashierUrl(cashierUrl.concat("?outTradeNo=").concat(mallBizPayment.getPayTradeNo()));
         RtMallDynamicProperty rtMallDynamicProperty = SpringContextUtils.getBean(RtMallDynamicProperty.class);
         RtMallDynamicProperty.AppSecretDynamicProperty property = rtMallDynamicProperty.getBySourceAndType(mallBizOrder.getSource(), mallBizOrder.getOrderType());
@@ -261,4 +271,18 @@ public class MallBizPayment extends BaseDO {
     public void setPaymentCallback(String paymentCallback) {
         this.paymentCallback = paymentCallback == null ? null : paymentCallback.trim();
     }
+
+    /**
+     * ofOrderPaymentVO
+     *
+     */
+    public OrderPaymentVO ofOrderPaymentVO() {
+        OrderPaymentVO orderPaymentVO = new OrderPaymentVO();
+        orderPaymentVO.setOutTradeNo(payTradeNo);
+        orderPaymentVO.setPayStatus(payState);
+        orderPaymentVO.setPayFee(payFee);
+        orderPaymentVO.setPayTime(payTime);
+        orderPaymentVO.setTransactionId(payPaymentId);
+        return orderPaymentVO;
+    }
 }
 package com.diligrp.cashier.mall.model;
+import com.diligrp.cashier.mall.domain.rtmall.co.RefundCO;
+import com.diligrp.cashier.mall.property.RtMallDynamicProperty;
 import com.diligrp.cashier.mall.type.RefundState;
+import com.diligrp.cashier.mall.util.MallSnowflakeKeyManager;
 import com.diligrp.cashier.shared.domain.BaseDO;
+import com.diligrp.cashier.shared.util.SpringContextUtils;
+import com.diligrp.cashier.trade.type.SnowflakeKey;
+import org.springframework.beans.BeanUtils;
 import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Optional;
 /**
  * MallBizRefund
@@ -98,16 +106,26 @@ public class MallBizRefund extends BaseDO {
     private String refundCallback;
     /**
+     * 创建人名称
+     */
+    private String createrName;
+
+    /**
      * 拒绝原因
      */
     private String refuseReason;
+    /**
+     * 退款商品列表
+     */
+    private List<MallBizRefundItem> refundItemList;
+
     public String getRefundTradeNo() {
         return refundTradeNo;
     }
     public void setRefundTradeNo(String refundTradeNo) {
-        this.refundTradeNo = refundTradeNo == null ? null : refundTradeNo.trim();
+        this.refundTradeNo = refundTradeNo;
     }
     public String getPayTradeNo() {
@@ -115,7 +133,7 @@ public class MallBizRefund extends BaseDO {
     }
     public void setPayTradeNo(String payTradeNo) {
-        this.payTradeNo = payTradeNo == null ? null : payTradeNo.trim();
+        this.payTradeNo = payTradeNo;
     }
     public String getRefundBn() {
@@ -123,7 +141,7 @@ public class MallBizRefund extends BaseDO {
     }
     public void setRefundBn(String refundBn) {
-        this.refundBn = refundBn == null ? null : refundBn.trim();
+        this.refundBn = refundBn;
     }
     public String getOrderId() {
@@ -131,7 +149,7 @@ public class MallBizRefund extends BaseDO {
     }
     public void setOrderId(String orderId) {
-        this.orderId = orderId == null ? null : orderId.trim();
+        this.orderId = orderId;
     }
     public String getTradeId() {
@@ -139,7 +157,7 @@ public class MallBizRefund extends BaseDO {
     }
     public void setTradeId(String tradeId) {
-        this.tradeId = tradeId == null ? null : tradeId.trim();
+        this.tradeId = tradeId;
     }
     public String getRefundPaymentId() {
@@ -147,7 +165,7 @@ public class MallBizRefund extends BaseDO {
     }
     public void setRefundPaymentId(String refundPaymentId) {
-        this.refundPaymentId = refundPaymentId == null ? null : refundPaymentId.trim();
+        this.refundPaymentId = refundPaymentId;
     }
     public String getPayPaymentId() {
@@ -155,7 +173,7 @@ public class MallBizRefund extends BaseDO {
     }
     public void setPayPaymentId(String payPaymentId) {
-        this.payPaymentId = payPaymentId == null ? null : payPaymentId.trim();
+        this.payPaymentId = payPaymentId;
     }
     public String getRefundCardNo() {
@@ -163,7 +181,7 @@ public class MallBizRefund extends BaseDO {
     }
     public void setRefundCardNo(String refundCardNo) {
-        this.refundCardNo = refundCardNo == null ? null : refundCardNo.trim();
+        this.refundCardNo = refundCardNo;
     }
     public Long getRefundUserId() {
@@ -179,7 +197,7 @@ public class MallBizRefund extends BaseDO {
     }
     public void setRefundUsername(String refundUsername) {
-        this.refundUsername = refundUsername == null ? null : refundUsername.trim();
+        this.refundUsername = refundUsername;
     }
     public Long getRefundAccountId() {
@@ -227,7 +245,7 @@ public class MallBizRefund extends BaseDO {
     }
     public void setRefundReason(String refundReason) {
-        this.refundReason = refundReason == null ? null : refundReason.trim();
+        this.refundReason = refundReason;
     }
     public String getRefundCallback() {
@@ -235,7 +253,15 @@ public class MallBizRefund extends BaseDO {
     }
     public void setRefundCallback(String refundCallback) {
-        this.refundCallback = refundCallback == null ? null : refundCallback.trim();
+        this.refundCallback = refundCallback;
+    }
+
+    public String getCreaterName() {
+        return createrName;
+    }
+
+    public void setCreaterName(String createrName) {
+        this.createrName = createrName;
     }
     public String getRefuseReason() {
@@ -243,6 +269,48 @@ public class MallBizRefund extends BaseDO {
     }
     public void setRefuseReason(String refuseReason) {
-        this.refuseReason = refuseReason == null ? null : refuseReason.trim();
+        this.refuseReason = refuseReason;
+    }
+
+    public List<MallBizRefundItem> getRefundItemList() {
+        return refundItemList;
+    }
+
+    public void setRefundItemList(List<MallBizRefundItem> refundItemList) {
+        this.refundItemList = refundItemList;
+    }
+
+    /**
+     * of
+     */
+    public static MallBizRefund of(final RefundCO refundCo,
+                                   final MallBizOrder mallBizOrder,
+                                   final MallBizPayment mallBizPayment) {
+        MallSnowflakeKeyManager snowflakeKeyManager = SpringContextUtils.getBean(MallSnowflakeKeyManager.class);
+
+        MallBizRefund mallBizRefund = new MallBizRefund();
+        mallBizRefund.setRefundTradeNo(snowflakeKeyManager.nextId(SnowflakeKey.MALL_BIZ_REFUND_ID).toString());
+        BeanUtils.copyProperties(refundCo, mallBizRefund);
+
+        mallBizRefund.setTradeId(mallBizPayment.getTradeId());
+        mallBizRefund.setPayTradeNo(mallBizPayment.getPayTradeNo());
+        mallBizRefund.setPayPaymentId(mallBizPayment.getPayPaymentId());
+
+        // 回调地址
+        RtMallDynamicProperty rtMallDynamicProperty = SpringContextUtils.getBean(RtMallDynamicProperty.class);
+        RtMallDynamicProperty.AppSecretDynamicProperty property = rtMallDynamicProperty.getBySourceAndType(mallBizOrder.getSource(), mallBizOrder.getOrderType());
+        mallBizRefund.setRefundCallback(property.getCallbackDomain());
+
+        // 退款商品明细
+        Optional.ofNullable(refundCo.getReturnItemList())
+                .ifPresent(items -> {
+                    List<MallBizRefundItem> list = items.stream().map(item -> {
+                        MallBizRefundItem mallBizRefundItem = new MallBizRefundItem();
+                        BeanUtils.copyProperties(item, mallBizRefundItem);
+                        return mallBizRefundItem;
+                    }).toList();
+                    mallBizRefund.setRefundItemList(list);
+                });
+        return mallBizRefund;
     }
 }
@@ -2,8 +2,11 @@ package com.diligrp.cashier.mall.service.biz;
 import com.diligrp.cashier.mall.domain.rtmall.co.OrderCO;
 import com.diligrp.cashier.mall.domain.rtmall.co.OrderInfoCO;
+import com.diligrp.cashier.mall.domain.rtmall.co.OrderStatusCallbackCO;
 import com.diligrp.cashier.mall.domain.rtmall.vo.OrderPaymentVO;
+import com.diligrp.cashier.mall.domain.rtmall.vo.OrderStatusCallbackVO;
 import com.diligrp.cashier.mall.domain.rtmall.vo.OrderSuccessVO;
+import com.diligrp.cashier.mall.model.MallBizOrder;
 /**
  * @ClassName MallBizOrderService.java
@@ -22,4 +25,14 @@ public interface MallBizOrderService {
      * info
      */
     OrderPaymentVO info(OrderInfoCO orderInfoCo);
+
+    /**
+     * statusCallback
+     */
+    OrderStatusCallbackVO statusCallback(OrderStatusCallbackCO orderStatusCallback);
+
+    /**
+     * getByOrderId
+     */
+    MallBizOrder getByOrderId(String orderId);
 }
 package com.diligrp.cashier.mall.service.biz;
+import com.diligrp.cashier.mall.domain.rtmall.vo.OrderPaymentVO;
 import com.diligrp.cashier.mall.model.MallBizPayment;
 /**
@@ -11,4 +12,6 @@ import com.diligrp.cashier.mall.model.MallBizPayment;
  */
 public interface MallBizPaymentService {
     void save(MallBizPayment mallBizPayment);
+
+    MallBizPayment paymentInfo(MallBizPayment mallBizPayment);
 }
+package com.diligrp.cashier.mall.service.biz;
+
+import com.diligrp.cashier.mall.domain.rtmall.co.RefundCO;
+import com.diligrp.cashier.mall.domain.rtmall.vo.RefundSuccessVO;
+
+/**
+ * @ClassName MallBizRefundService.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description MallBizRefundService
+ */
+public interface MallBizRefundService {
+    RefundSuccessVO refund(RefundCO refundCo);
+}
@@ -7,7 +7,9 @@ import com.diligrp.cashier.mall.dao.MallBizOrderItemDao;
 import com.diligrp.cashier.mall.domain.rtmall.co.AuthLoginCO;
 import com.diligrp.cashier.mall.domain.rtmall.co.OrderCO;
 import com.diligrp.cashier.mall.domain.rtmall.co.OrderInfoCO;
+import com.diligrp.cashier.mall.domain.rtmall.co.OrderStatusCallbackCO;
 import com.diligrp.cashier.mall.domain.rtmall.vo.OrderPaymentVO;
+import com.diligrp.cashier.mall.domain.rtmall.vo.OrderStatusCallbackVO;
 import com.diligrp.cashier.mall.domain.rtmall.vo.OrderSuccessVO;
 import com.diligrp.cashier.mall.exception.RtMartMallException;
 import com.diligrp.cashier.mall.model.MallBizOrder;
@@ -15,12 +17,11 @@ import com.diligrp.cashier.mall.model.MallBizPayment;
 import com.diligrp.cashier.mall.service.biz.MallBizOrderService;
 import com.diligrp.cashier.mall.service.biz.MallBizPaymentService;
 import com.diligrp.cashier.mall.type.RtMarkErrorCode;
-import com.diligrp.cashier.mall.util.MallSnowflakeKeyManager;
 import com.diligrp.cashier.shared.util.JsonUtils;
-import com.diligrp.cashier.trade.type.SnowflakeKey;
 import jakarta.annotation.Resource;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.BeanUtils;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -42,8 +43,6 @@ public class MallBizOrderServiceImpl implements MallBizOrderService {
     @Resource
     private RedisTemplate<String, Object> redisTemplate;
     @Resource
-    private MallSnowflakeKeyManager mallSnowflakeKeyManager;
-    @Resource
     private MallBizPaymentService mallBizPaymentService;
     @Resource
     private MallBizOrderDao mallBizOrderDao;
@@ -69,7 +68,7 @@ public class MallBizOrderServiceImpl implements MallBizOrderService {
         // save
         commonCreate(mallBizOrder, mallBizPayment);
-        return new OrderSuccessVO(mallSnowflakeKeyManager.nextId(SnowflakeKey.MALL_BIZ_ORDER_ID).toString(), "https://www.baidu.com");
+        return new OrderSuccessVO(mallBizPayment.getPayTradeNo(), mallBizPayment.getCashierUrl());
     }
     /**
@@ -78,7 +77,31 @@ public class MallBizOrderServiceImpl implements MallBizOrderService {
      */
     @Override
     public OrderPaymentVO info(OrderInfoCO orderInfoCo) {
-        return null;
+        MallBizPayment mallBizPayment = new MallBizPayment();
+        BeanUtils.copyProperties(orderInfoCo, mallBizPayment);
+        mallBizPayment = mallBizPaymentService.paymentInfo(mallBizPayment);
+        return mallBizPayment.ofOrderPaymentVO();
+    }
+
+    /**
+     * statusCallback
+     */
+    @Override
+    @Transactional(rollbackFor = {Exception.class})
+    public OrderStatusCallbackVO statusCallback(OrderStatusCallbackCO orderStatusCallback) {
+        // update order status
+        MallBizOrder mallBizOrder = getByOrderId(orderStatusCallback.getOrderId());
+
+        MallBizOrder update = mallBizOrder.ofUpdateState(orderStatusCallback);
+        int num = mallBizOrderDao.updateByPrimaryKeySelective(update);
+        if (num < 1) {
+            throw new RtMartMallException(RtMarkErrorCode.E5004);
+        }
+
+        MallBizPayment mallBizPayment = new MallBizPayment();
+        BeanUtils.copyProperties(orderStatusCallback, mallBizPayment);
+        mallBizPayment = mallBizPaymentService.paymentInfo(mallBizPayment);
+        return new OrderStatusCallbackVO(mallBizPayment.getPayTradeNo());
     }
     /**
@@ -111,4 +134,17 @@ public class MallBizOrderServiceImpl implements MallBizOrderService {
         Optional.ofNullable(mallBizPayment).ifPresent(mallBizPaymentService::save);
     }
+
+    /**
+     * getByOrderId
+     *
+     */
+    @Override
+    public MallBizOrder getByOrderId(String orderId) {
+        MallBizOrder mallBizOrder = mallBizOrderDao.getByOrderId(orderId);
+        if (Objects.isNull(mallBizOrder)) {
+            throw new RtMartMallException(RtMarkErrorCode.E5004);
+        }
+        return mallBizOrder;
+    }
 }
 package com.diligrp.cashier.mall.service.biz.impl;
 import com.diligrp.cashier.mall.dao.MallBizPaymentDao;
+import com.diligrp.cashier.mall.domain.rtmall.co.OrderInfoCO;
+import com.diligrp.cashier.mall.domain.rtmall.vo.OrderPaymentVO;
 import com.diligrp.cashier.mall.model.MallBizPayment;
 import com.diligrp.cashier.mall.service.biz.MallBizPaymentService;
 import jakarta.annotation.Resource;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -23,9 +26,22 @@ public class MallBizPaymentServiceImpl implements MallBizPaymentService {
     @Resource
     private MallBizPaymentDao mallBizPaymentDao;
+    /**
+     * save
+     *
+     */
     @Override
     @Transactional(rollbackFor = {Exception.class})
     public void save(MallBizPayment mallBizPayment) {
         mallBizPaymentDao.insertSelective(mallBizPayment);
     }
+
+    /**
+     * paymentInfo
+     *
+     */
+    @Override
+    public MallBizPayment paymentInfo(MallBizPayment mallBizPayment) {
+        return mallBizPaymentDao.getMallBizPayment(mallBizPayment);
+    }
 }
+package com.diligrp.cashier.mall.service.biz.impl;
+
+import com.diligrp.cashier.mall.context.MallInitializeContext;
+import com.diligrp.cashier.mall.dao.MallBizOrderDao;
+import com.diligrp.cashier.mall.dao.MallBizRefundDao;
+import com.diligrp.cashier.mall.dao.MallBizRefundItemDao;
+import com.diligrp.cashier.mall.domain.rtmall.co.RefundCO;
+import com.diligrp.cashier.mall.domain.rtmall.vo.RefundSuccessVO;
+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.MallBizRefund;
+import com.diligrp.cashier.mall.service.biz.MallBizPaymentService;
+import com.diligrp.cashier.mall.service.biz.MallBizRefundService;
+import com.diligrp.cashier.mall.type.RtMarkErrorCode;
+import jakarta.annotation.Resource;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Objects;
+
+/**
+ * @ClassName MallBizRefundServiceImpl.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description MallBizRefundServiceImpl
+ */
+@Service
+public class MallBizRefundServiceImpl implements MallBizRefundService {
+    private static final Logger log = LoggerFactory.getLogger(MallBizRefundServiceImpl.class);
+
+    @Resource
+    private MallBizOrderDao mallBizOrderDao;
+    @Resource
+    private MallBizPaymentService mallBizPaymentService;
+    @Resource
+    private MallBizRefundDao mallBizRefundDao;
+
+    /**
+     * refund
+     * 退款成功回调
+     */
+    @Override
+    @Transactional(rollbackFor = {Exception.class})
+    public RefundSuccessVO refund(RefundCO refundCo) {
+        MallBizOrder mallBizOrder = mallBizOrderDao.getByOrderId(refundCo.getOrderId());
+        MallBizRefund mallBizRefund = MallInitializeContext.getBySource(mallBizOrder.getSource()).refund(refundCo);
+        return new RefundSuccessVO(mallBizRefund.getPayTradeNo(), mallBizRefund.getRefundTradeNo());
+    }
+
+    /**
+     * getPayment
+     */
+    private MallBizPayment getPayment(RefundCO refundCo) {
+        MallBizPayment mallBizPayment = mallBizPaymentService.paymentInfo(new MallBizPayment(refundCo.getOrderId(), null));
+        if (Objects.isNull(mallBizPayment)) {
+            throw new RtMartMallException(RtMarkErrorCode.E5004);
+        }
+        return mallBizPayment;
+    }
+}
@@ -8,7 +8,7 @@ import org.slf4j.LoggerFactory;
  * @author dengwei
  * @version 1.0.0
  * @Description AbstractPayChannel
- * @date 2025-12-25 17:07
+ * 支付渠道抽象层
  */
 public abstract class AbstractPayChannel {
     protected final Logger log = LoggerFactory.getLogger(getClass());
 package com.diligrp.cashier.mall.service.paychannel;
+import com.diligrp.cashier.mall.type.PaymentChanel;
 import org.springframework.stereotype.Component;
 /**
@@ -7,12 +8,12 @@ import org.springframework.stereotype.Component;
  * @author dengwei
  * @version 1.0.0
  * @Description CardPayChannel
- * @date 2025-12-25 17:08
+ * 园区卡支付渠道
  */
 @Component
 public class CardPayChannel extends AbstractPayChannel {
     @Override
     public Integer getPayChannel() {
-        return 0;
+        return PaymentChanel.PARK_CARD.getCode();
     }
 }
 package com.diligrp.cashier.mall.service.paychannel;
+import com.diligrp.cashier.mall.type.PaymentChanel;
 import org.springframework.stereotype.Component;
 /**
@@ -7,12 +8,12 @@ import org.springframework.stereotype.Component;
  * @author dengwei
  * @version 1.0.0
  * @Description WeChatPayChannel
- * @date 2025-12-25 17:08
+ * 微信支付渠道
  */
 @Component
 public class WeChatPayChannel extends AbstractPayChannel {
     @Override
     public Integer getPayChannel() {
-        return 1;
+        return PaymentChanel.WECHAT.getCode();
     }
 }
@@ -2,16 +2,29 @@ package com.diligrp.cashier.mall.service.sourcechannel;
 import cn.hutool.core.util.IdUtil;
 import com.diligrp.cashier.mall.MallConstants;
+import com.diligrp.cashier.mall.dao.MallBizOrderDao;
+import com.diligrp.cashier.mall.dao.MallBizRefundDao;
+import com.diligrp.cashier.mall.dao.MallBizRefundItemDao;
 import com.diligrp.cashier.mall.domain.rtmall.co.AuthLoginCO;
+import com.diligrp.cashier.mall.domain.rtmall.co.RefundCO;
 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.MallBizRefund;
 import com.diligrp.cashier.mall.property.RtMallDynamicProperty;
+import com.diligrp.cashier.mall.service.biz.MallBizPaymentService;
+import com.diligrp.cashier.mall.type.RtMarkErrorCode;
 import com.diligrp.cashier.shared.util.DateUtils;
 import com.diligrp.cashier.shared.util.JsonUtils;
 import jakarta.annotation.Resource;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.transaction.annotation.Transactional;
+import java.util.Objects;
+import java.util.Optional;
 import java.util.concurrent.TimeUnit;
 /**
@@ -19,15 +32,24 @@ import java.util.concurrent.TimeUnit;
  * @author dengwei
  * @version 1.0.0
  * @Description AbstractChannel
+ * 对接收银台订单来源抽象
  * @date 2025-12-25 11:19
  */
-public abstract class AbstractChannel {
-    private static final Logger log = LoggerFactory.getLogger(AbstractChannel.class);
+public abstract class AbstractSourceChannel {
+    private static final Logger log = LoggerFactory.getLogger(AbstractSourceChannel.class);
     @Resource
     protected RtMallDynamicProperty rtMallDynamicProperty;
     @Resource
     protected RedisTemplate<String, Object> redisTemplate;
+    @Resource
+    protected MallBizOrderDao mallBizOrderDao;
+    @Resource
+    protected MallBizPaymentService mallBizPaymentService;
+    @Resource
+    protected MallBizRefundDao mallBizRefundDao;
+    @Resource
+    protected MallBizRefundItemDao mallBizRefundItemDao;
     /**
      * authLogin
@@ -65,6 +87,21 @@ public abstract class AbstractChannel {
     }
     /**
+     * refund
+     */
+    @Transactional(rollbackFor = {Exception.class})
+    public MallBizRefund refund(RefundCO refundCo) {
+        MallBizOrder mallBizOrder = mallBizOrderDao.getByOrderId(refundCo.getOrderId());
+        MallBizPayment mallBizPayment = getPayment(refundCo);
+
+        // TODO 2025/12/30: 调用支付完善信息
+        MallBizRefund refund = MallBizRefund.of(refundCo, mallBizOrder, mallBizPayment);
+
+        save(refund);
+        return refund;
+    }
+
+    /**
      * 渠道
      */
     public abstract Integer source();
@@ -74,5 +111,32 @@ public abstract class AbstractChannel {
      */
     public abstract String authUrl(AuthLoginCO authLogin, String token, long timestamp);
+    /**
+     * userInfoChannel
+     */
     public abstract void userInfoChannel(UserInfoVO authLogin, RtMallDynamicProperty.AppSecretDynamicProperty userInfoVO);
+
+    /**
+     * getPayment
+     */
+    private MallBizPayment getPayment(RefundCO refundCo) {
+        MallBizPayment mallBizPayment = mallBizPaymentService.paymentInfo(new MallBizPayment(refundCo.getOrderId(), null));
+        if (Objects.isNull(mallBizPayment)) {
+            throw new RtMartMallException(RtMarkErrorCode.E5004);
+        }
+        return mallBizPayment;
+    }
+
+    /**
+     * save
+     */
+    private void save(MallBizRefund refund) {
+        mallBizRefundDao.insertSelective(refund);
+        // 退款商品明细
+        Optional.ofNullable(refund.getRefundItemList())
+                .ifPresent(items -> {
+                    items.forEach(item -> item.setBizRefundId(refund.getId()));
+                    mallBizRefundItemDao.batchInsert(items);
+                });
+    }
 }
@@ -18,10 +18,11 @@ import java.util.Map;
  * @author dengwei
  * @version 1.0.0
  * @Description RtMallChannel
+ * 大润发订单来源渠道
  * @date 2025-12-25 11:20
  */
 @Component
-public class RtMallChannel extends AbstractChannel {
+public class RtMallChannel extends AbstractSourceChannel {
     private static final Logger log = LoggerFactory.getLogger(RtMallChannel.class);
     @Override
 package com.diligrp.cashier.mall.type;
+import com.diligrp.cashier.mall.exception.RtMartMallException;
+
+import java.util.Arrays;
+import java.util.Map;
+import java.util.Optional;
+import java.util.stream.Collectors;
+
 /**
  * @ClassName OrderStatus.java
  * @author dengwei
@@ -12,6 +19,7 @@ public enum OrderState {
     NOT_PAY_CANCEL(2, "notpaycancel", "未支付取消"),
     PAYED_CANCEL(3, "payedcancel", "已支付取消"),
     DONE(4, "done", "订单完成"),
+    CONFIRM_RECEIPT(4, "confirmreceipt", "订单完成"),
     BUYER_CONFIRM(5, "buyer_confirm", "待用户收货"),
     ;
@@ -36,4 +44,14 @@ public enum OrderState {
     public String getName() {
         return name;
     }
+
+    /**
+     * getCode
+     * 根据key获取code
+     *
+     */
+    public static Integer getCode(String key) {
+        Map<String, Integer> keyCodeMap = Arrays.stream(values()).collect(Collectors.toMap(OrderState::getKey, OrderState::getCode));
+        return Optional.ofNullable(keyCodeMap.get(key)).orElseThrow(() -> new RtMartMallException(RtMarkErrorCode.E5003));
+    }
 }
+package com.diligrp.cashier.mall.type;
+
+/**
+ * @ClassName PaymentChanel.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description PaymentChanel
+ */
+public enum PaymentChanel {
+    WECHAT(10, "微信"),
+    PARK_CARD(19, "园区卡");
+
+    private final int code;
+    private final String description;
+
+    PaymentChanel(int code, String description) {
+        this.code = code;
+        this.description = description;
+    }
+
+    public int getCode() {
+        return code;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+}
@@ -17,6 +17,8 @@ public enum RtMarkErrorCode {
     E5000("E5000", "未知错误"),
     E5001("E5001", "认证失败"),
     E5002("E5002", "不支持的类型"),
+    E5003("E5003", "回调状态不匹配"),
+    E5004("E5004", "数据异常"),
     ;
     public final String code;
@@ -23,12 +23,13 @@
     <result column="order_expire" jdbcType="INTEGER" property="orderExpire" />
     <result column="version" jdbcType="INTEGER" property="version" />
     <result column="created_time" jdbcType="TIMESTAMP" property="createdTime" />
+    <result column="modifier_name" jdbcType="VARCHAR" property="modifierName" />
     <result column="modified_time" jdbcType="TIMESTAMP" property="modifiedTime" />
   </resultMap>
   <sql id="Base_Column_List">
     id, order_no, order_id, trade_id, channel, mch_id, source, order_type, user_code,
     username, company_code, shop_code, shop_name, total_amount, freight_fee, state,
-    rtmart_state, order_time, order_expire, version, created_time, modified_time
+    rtmart_state, order_time, order_expire, version, created_time, modifier_name, modified_time
   </sql>
   <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
     select
@@ -47,16 +48,14 @@
       username, company_code, shop_code,
       shop_name, total_amount, freight_fee,
       state, rtmart_state, order_time,
-      order_expire, version, created_time,
-      modified_time)
+      order_expire)
     values (#{id,jdbcType=BIGINT}, #{orderNo,jdbcType=VARCHAR}, #{orderId,jdbcType=VARCHAR},
       #{tradeId,jdbcType=VARCHAR}, #{channel,jdbcType=VARCHAR}, #{mchId,jdbcType=VARCHAR},
       #{source,jdbcType=TINYINT}, #{orderType,jdbcType=TINYINT}, #{userCode,jdbcType=VARCHAR},
       #{username,jdbcType=VARCHAR}, #{companyCode,jdbcType=VARCHAR}, #{shopCode,jdbcType=VARCHAR},
       #{shopName,jdbcType=VARCHAR}, #{totalAmount,jdbcType=BIGINT}, #{freightFee,jdbcType=BIGINT},
       #{state,jdbcType=TINYINT}, #{rtmartState,jdbcType=TINYINT}, #{orderTime,jdbcType=TIMESTAMP},
-      #{orderExpire,jdbcType=INTEGER}, #{version,jdbcType=INTEGER}, #{createdTime,jdbcType=TIMESTAMP},
-      #{modifiedTime,jdbcType=TIMESTAMP})
+      #{orderExpire,jdbcType=INTEGER})
   </insert>
   <insert id="insertSelective" parameterType="com.diligrp.cashier.mall.model.MallBizOrder">
     insert into mall_biz_order
@@ -254,18 +253,21 @@
       <if test="orderExpire != null">
         order_expire = #{orderExpire,jdbcType=INTEGER},
       </if>
-      <if test="version != null">
-        version = #{version,jdbcType=INTEGER},
-      </if>
       <if test="createdTime != null">
         created_time = #{createdTime,jdbcType=TIMESTAMP},
       </if>
+      <if test="modifierName != null">
+        modifier_name = #{modifierName,jdbcType=VARCHAR},
+      </if>
       <if test="modifiedTime != null">
         modified_time = #{modifiedTime,jdbcType=TIMESTAMP},
       </if>
+      version = version + 1,
     </set>
     where id = #{id,jdbcType=BIGINT}
+    and version = #{version}
   </update>
+
   <update id="updateByPrimaryKey" parameterType="com.diligrp.cashier.mall.model.MallBizOrder">
     update mall_biz_order
     set order_no = #{orderNo,jdbcType=VARCHAR},
@@ -286,9 +288,55 @@
       rtmart_state = #{rtmartState,jdbcType=TINYINT},
       order_time = #{orderTime,jdbcType=TIMESTAMP},
       order_expire = #{orderExpire,jdbcType=INTEGER},
-      version = #{version,jdbcType=INTEGER},
-      created_time = #{createdTime,jdbcType=TIMESTAMP},
-      modified_time = #{modifiedTime,jdbcType=TIMESTAMP}
+      modifier_name = #{modifierName,jdbcType=VARCHAR},
     where id = #{id,jdbcType=BIGINT}
   </update>
+
+    <select id="getByOrderId" resultType="com.diligrp.cashier.mall.model.MallBizOrder">
+        select <include refid="Base_Column_List"/>
+        from mall_biz_order
+        where order_id = #{orderId}
+    </select>
+
+    <update id="update">
+        update mall_biz_order
+        <set>
+            <if test="tradeId != null">
+                trade_id = #{tradeId,jdbcType=VARCHAR},
+            </if>
+            <if test="username != null">
+                username = #{username,jdbcType=VARCHAR},
+            </if>
+            <if test="companyCode != null">
+                company_code = #{companyCode,jdbcType=VARCHAR},
+            </if>
+            <if test="shopCode != null">
+                shop_code = #{shopCode,jdbcType=VARCHAR},
+            </if>
+            <if test="shopName != null">
+                shop_name = #{shopName,jdbcType=VARCHAR},
+            </if>
+            <if test="totalAmount != null">
+                total_amount = #{totalAmount,jdbcType=BIGINT},
+            </if>
+            <if test="freightFee != null">
+                freight_fee = #{freightFee,jdbcType=BIGINT},
+            </if>
+            <if test="state != null">
+                state = #{state,jdbcType=TINYINT},
+            </if>
+            <if test="rtmartState != null">
+                rtmart_state = #{rtmartState,jdbcType=TINYINT},
+            </if>
+            <if test="orderExpire != null">
+                order_expire = #{orderExpire,jdbcType=INTEGER},
+            </if>
+            version = version + 1
+        </set>
+        where order_id = #{orderId}
+        <if test="tradeId != null and tradeId != ''">
+            and trade_id = #{tradeId}
+        </if>
+        and version = #{version}
+    </update>
 </mapper>
@@ -35,7 +35,7 @@
     from mall_biz_payment
     where id = #{id,jdbcType=BIGINT}
   </select>
-  <delete id="deleteByPrimaryKey" parameterType="java.lang.Long">
+    <delete id="deleteByPrimaryKey" parameterType="java.lang.Long">
     delete from mall_biz_payment
     where id = #{id,jdbcType=BIGINT}
   </delete>
@@ -280,4 +280,14 @@
       modified_time = #{modifiedTime,jdbcType=TIMESTAMP}
     where id = #{id,jdbcType=BIGINT}
   </update>
+
+    <select id="getMallBizPayment" resultType="com.diligrp.cashier.mall.model.MallBizPayment">
+        select
+        <include refid="Base_Column_List" />
+        from mall_biz_payment
+        where order_id = #{orderId}
+        <if test="tradeId != null and tradeId != ''">
+            and trade_id = #{tradeId}
+        </if>
+    </select>
 </mapper>
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.diligrp.cashier.mall.dao.MallBizRefundDao">
+  <resultMap id="BaseResultMap" type="com.diligrp.cashier.mall.model.MallBizRefund">
+    <id column="id" jdbcType="BIGINT" property="id" />
+    <result column="refund_trade_no" jdbcType="VARCHAR" property="refundTradeNo" />
+    <result column="pay_trade_no" jdbcType="VARCHAR" property="payTradeNo" />
+    <result column="refund_bn" jdbcType="VARCHAR" property="refundBn" />
+    <result column="order_id" jdbcType="VARCHAR" property="orderId" />
+    <result column="trade_id" jdbcType="VARCHAR" property="tradeId" />
+    <result column="refund_payment_id" jdbcType="VARCHAR" property="refundPaymentId" />
+    <result column="pay_payment_id" jdbcType="VARCHAR" property="payPaymentId" />
+    <result column="refund_card_no" jdbcType="VARCHAR" property="refundCardNo" />
+    <result column="refund_user_id" jdbcType="BIGINT" property="refundUserId" />
+    <result column="refund_username" jdbcType="VARCHAR" property="refundUsername" />
+    <result column="refund_account_id" jdbcType="BIGINT" property="refundAccountId" />
+    <result column="refund_time" jdbcType="TIMESTAMP" property="refundTime" />
+    <result column="refund_fee" jdbcType="BIGINT" property="refundFee" />
+    <result column="freight_fee" jdbcType="BIGINT" property="freightFee" />
+    <result column="refund_state" jdbcType="TINYINT" property="refundState" />
+    <result column="refund_reason" jdbcType="VARCHAR" property="refundReason" />
+    <result column="refund_callback" jdbcType="VARCHAR" property="refundCallback" />
+    <result column="version" jdbcType="INTEGER" property="version" />
+    <result column="creater_name" jdbcType="VARCHAR" property="createrName" />
+    <result column="created_time" jdbcType="TIMESTAMP" property="createdTime" />
+    <result column="refuse_reason" jdbcType="VARCHAR" property="refuseReason" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    id, refund_trade_no, pay_trade_no, refund_bn, order_id, trade_id, refund_payment_id,
+    pay_payment_id, refund_card_no, refund_user_id, refund_username, refund_account_id,
+    refund_time, refund_fee, freight_fee, refund_state, refund_reason, refund_callback,
+    version, creater_name, created_time, refuse_reason
+  </sql>
+  <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
+    select
+    <include refid="Base_Column_List" />
+    from mall_biz_refund
+    where id = #{id,jdbcType=BIGINT}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.Long">
+    delete from mall_biz_refund
+    where id = #{id,jdbcType=BIGINT}
+  </delete>
+  <insert id="insert" parameterType="com.diligrp.cashier.mall.model.MallBizRefund">
+    insert into mall_biz_refund (id, refund_trade_no, pay_trade_no,
+      refund_bn, order_id, trade_id,
+      refund_payment_id, pay_payment_id, refund_card_no,
+      refund_user_id, refund_username, refund_account_id,
+      refund_time, refund_fee, freight_fee,
+      refund_state, refund_reason, refund_callback,
+      version, creater_name, created_time,
+      refuse_reason)
+    values (#{id,jdbcType=BIGINT}, #{refundTradeNo,jdbcType=VARCHAR}, #{payTradeNo,jdbcType=VARCHAR},
+      #{refundBn,jdbcType=VARCHAR}, #{orderId,jdbcType=VARCHAR}, #{tradeId,jdbcType=VARCHAR},
+      #{refundPaymentId,jdbcType=VARCHAR}, #{payPaymentId,jdbcType=VARCHAR}, #{refundCardNo,jdbcType=VARCHAR},
+      #{refundUserId,jdbcType=BIGINT}, #{refundUsername,jdbcType=VARCHAR}, #{refundAccountId,jdbcType=BIGINT},
+      #{refundTime,jdbcType=TIMESTAMP}, #{refundFee,jdbcType=BIGINT}, #{freightFee,jdbcType=BIGINT},
+      #{refundState,jdbcType=TINYINT}, #{refundReason,jdbcType=VARCHAR}, #{refundCallback,jdbcType=VARCHAR},
+      #{version,jdbcType=INTEGER}, #{createrName,jdbcType=VARCHAR}, #{createdTime,jdbcType=TIMESTAMP},
+      #{refuseReason,jdbcType=VARCHAR})
+  </insert>
+  <insert id="insertSelective" parameterType="com.diligrp.cashier.mall.model.MallBizRefund"
+          useGeneratedKeys="true" keyColumn="id">
+    insert into mall_biz_refund
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="refundTradeNo != null">
+        refund_trade_no,
+      </if>
+      <if test="payTradeNo != null">
+        pay_trade_no,
+      </if>
+      <if test="refundBn != null">
+        refund_bn,
+      </if>
+      <if test="orderId != null">
+        order_id,
+      </if>
+      <if test="tradeId != null">
+        trade_id,
+      </if>
+      <if test="refundPaymentId != null">
+        refund_payment_id,
+      </if>
+      <if test="payPaymentId != null">
+        pay_payment_id,
+      </if>
+      <if test="refundCardNo != null">
+        refund_card_no,
+      </if>
+      <if test="refundUserId != null">
+        refund_user_id,
+      </if>
+      <if test="refundUsername != null">
+        refund_username,
+      </if>
+      <if test="refundAccountId != null">
+        refund_account_id,
+      </if>
+      <if test="refundTime != null">
+        refund_time,
+      </if>
+      <if test="refundFee != null">
+        refund_fee,
+      </if>
+      <if test="freightFee != null">
+        freight_fee,
+      </if>
+      <if test="refundState != null">
+        refund_state,
+      </if>
+      <if test="refundReason != null">
+        refund_reason,
+      </if>
+      <if test="refundCallback != null">
+        refund_callback,
+      </if>
+      <if test="version != null">
+        version,
+      </if>
+      <if test="createrName != null">
+        creater_name,
+      </if>
+      <if test="createdTime != null">
+        created_time,
+      </if>
+      <if test="refuseReason != null">
+        refuse_reason,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=BIGINT},
+      </if>
+      <if test="refundTradeNo != null">
+        #{refundTradeNo,jdbcType=VARCHAR},
+      </if>
+      <if test="payTradeNo != null">
+        #{payTradeNo,jdbcType=VARCHAR},
+      </if>
+      <if test="refundBn != null">
+        #{refundBn,jdbcType=VARCHAR},
+      </if>
+      <if test="orderId != null">
+        #{orderId,jdbcType=VARCHAR},
+      </if>
+      <if test="tradeId != null">
+        #{tradeId,jdbcType=VARCHAR},
+      </if>
+      <if test="refundPaymentId != null">
+        #{refundPaymentId,jdbcType=VARCHAR},
+      </if>
+      <if test="payPaymentId != null">
+        #{payPaymentId,jdbcType=VARCHAR},
+      </if>
+      <if test="refundCardNo != null">
+        #{refundCardNo,jdbcType=VARCHAR},
+      </if>
+      <if test="refundUserId != null">
+        #{refundUserId,jdbcType=BIGINT},
+      </if>
+      <if test="refundUsername != null">
+        #{refundUsername,jdbcType=VARCHAR},
+      </if>
+      <if test="refundAccountId != null">
+        #{refundAccountId,jdbcType=BIGINT},
+      </if>
+      <if test="refundTime != null">
+        #{refundTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="refundFee != null">
+        #{refundFee,jdbcType=BIGINT},
+      </if>
+      <if test="freightFee != null">
+        #{freightFee,jdbcType=BIGINT},
+      </if>
+      <if test="refundState != null">
+        #{refundState,jdbcType=TINYINT},
+      </if>
+      <if test="refundReason != null">
+        #{refundReason,jdbcType=VARCHAR},
+      </if>
+      <if test="refundCallback != null">
+        #{refundCallback,jdbcType=VARCHAR},
+      </if>
+      <if test="version != null">
+        #{version,jdbcType=INTEGER},
+      </if>
+      <if test="createrName != null">
+        #{createrName,jdbcType=VARCHAR},
+      </if>
+      <if test="createdTime != null">
+        #{createdTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="refuseReason != null">
+        #{refuseReason,jdbcType=VARCHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.diligrp.cashier.mall.model.MallBizRefund">
+    update mall_biz_refund
+    <set>
+      <if test="refundTradeNo != null">
+        refund_trade_no = #{refundTradeNo,jdbcType=VARCHAR},
+      </if>
+      <if test="payTradeNo != null">
+        pay_trade_no = #{payTradeNo,jdbcType=VARCHAR},
+      </if>
+      <if test="refundBn != null">
+        refund_bn = #{refundBn,jdbcType=VARCHAR},
+      </if>
+      <if test="orderId != null">
+        order_id = #{orderId,jdbcType=VARCHAR},
+      </if>
+      <if test="tradeId != null">
+        trade_id = #{tradeId,jdbcType=VARCHAR},
+      </if>
+      <if test="refundPaymentId != null">
+        refund_payment_id = #{refundPaymentId,jdbcType=VARCHAR},
+      </if>
+      <if test="payPaymentId != null">
+        pay_payment_id = #{payPaymentId,jdbcType=VARCHAR},
+      </if>
+      <if test="refundCardNo != null">
+        refund_card_no = #{refundCardNo,jdbcType=VARCHAR},
+      </if>
+      <if test="refundUserId != null">
+        refund_user_id = #{refundUserId,jdbcType=BIGINT},
+      </if>
+      <if test="refundUsername != null">
+        refund_username = #{refundUsername,jdbcType=VARCHAR},
+      </if>
+      <if test="refundAccountId != null">
+        refund_account_id = #{refundAccountId,jdbcType=BIGINT},
+      </if>
+      <if test="refundTime != null">
+        refund_time = #{refundTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="refundFee != null">
+        refund_fee = #{refundFee,jdbcType=BIGINT},
+      </if>
+      <if test="freightFee != null">
+        freight_fee = #{freightFee,jdbcType=BIGINT},
+      </if>
+      <if test="refundState != null">
+        refund_state = #{refundState,jdbcType=TINYINT},
+      </if>
+      <if test="refundReason != null">
+        refund_reason = #{refundReason,jdbcType=VARCHAR},
+      </if>
+      <if test="refundCallback != null">
+        refund_callback = #{refundCallback,jdbcType=VARCHAR},
+      </if>
+      <if test="version != null">
+        version = #{version,jdbcType=INTEGER},
+      </if>
+      <if test="createrName != null">
+        creater_name = #{createrName,jdbcType=VARCHAR},
+      </if>
+      <if test="createdTime != null">
+        created_time = #{createdTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="refuseReason != null">
+        refuse_reason = #{refuseReason,jdbcType=VARCHAR},
+      </if>
+    </set>
+    where id = #{id,jdbcType=BIGINT}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.diligrp.cashier.mall.model.MallBizRefund">
+    update mall_biz_refund
+    set refund_trade_no = #{refundTradeNo,jdbcType=VARCHAR},
+      pay_trade_no = #{payTradeNo,jdbcType=VARCHAR},
+      refund_bn = #{refundBn,jdbcType=VARCHAR},
+      order_id = #{orderId,jdbcType=VARCHAR},
+      trade_id = #{tradeId,jdbcType=VARCHAR},
+      refund_payment_id = #{refundPaymentId,jdbcType=VARCHAR},
+      pay_payment_id = #{payPaymentId,jdbcType=VARCHAR},
+      refund_card_no = #{refundCardNo,jdbcType=VARCHAR},
+      refund_user_id = #{refundUserId,jdbcType=BIGINT},
+      refund_username = #{refundUsername,jdbcType=VARCHAR},
+      refund_account_id = #{refundAccountId,jdbcType=BIGINT},
+      refund_time = #{refundTime,jdbcType=TIMESTAMP},
+      refund_fee = #{refundFee,jdbcType=BIGINT},
+      freight_fee = #{freightFee,jdbcType=BIGINT},
+      refund_state = #{refundState,jdbcType=TINYINT},
+      refund_reason = #{refundReason,jdbcType=VARCHAR},
+      refund_callback = #{refundCallback,jdbcType=VARCHAR},
+      version = #{version,jdbcType=INTEGER},
+      creater_name = #{createrName,jdbcType=VARCHAR},
+      created_time = #{createdTime,jdbcType=TIMESTAMP},
+      refuse_reason = #{refuseReason,jdbcType=VARCHAR}
+    where id = #{id,jdbcType=BIGINT}
+  </update>
+</mapper>
@@ -80,7 +80,7 @@
       </if>
     </trim>
   </insert>
-  <update id="updateByPrimaryKeySelective" parameterType="com.diligrp.cashier.mall.model.MallBizRefundItem">
+    <update id="updateByPrimaryKeySelective" parameterType="com.diligrp.cashier.mall.model.MallBizRefundItem">
     update mall_biz_refund_item
     <set>
       <if test="bizRefundId != null">
@@ -114,4 +114,17 @@
       refund_fee = #{refundFee,jdbcType=BIGINT}
     where id = #{id,jdbcType=BIGINT}
   </update>
+
+  <insert id="batchInsert">
+      insert into mall_biz_refund_item (biz_refund_id, sub_order_id,
+        item_bn, item_name, num,
+        refund_fee)
+      values
+      <foreach collection="list" item="item" index="index" separator=",">
+        (#{item.bizRefundId,jdbcType=BIGINT}, #{item.subOrderId,jdbcType=BIGINT},
+        #{item.itemBn,jdbcType=VARCHAR}, #{item.itemName,jdbcType=VARCHAR}, #{item.num,jdbcType=INTEGER},
+        #{item.refundFee,jdbcType=BIGINT})
+      </foreach>
+  </insert>
+
 </mapper>
-{
-  "name": "resources",
-  "version": "1.0.0",
-  "description": "",
-  "main": "index.js",
-  "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1"
-  },
-  "repository": {
-    "type": "git",
-    "url": "https://git3.nong12.com/cashierdesk/dili-cashier.git"
-  },
-  "private": true
-}