feat hourbuy init

dengwei
1 parent 30fe1245
Showing 48 changed files with 1305 additions and 95 deletions
cashier-boss/src/main/java/com/diligrp/cashier/boss/aop/LogPrintAop.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/MallConstants.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/api/MallAuthApi.java
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/MallBizOrderAddressDao.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/dao/MallBizOrderDao.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/dao/MallBizOrderItemDao.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/dao/MallBizPaymentDao.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/dao/MallBizRefundItemDao.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/RtMarkMessage.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/co/OrderCO.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/co/OrderInfoCO.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/co/OrderItemCO.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/co/ReceiverInfoCO.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/OrderSuccessVO.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/model/MallBizOrder.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/model/MallBizOrderItem.java
@@ -14,6 +14,8 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.core.annotation.Order;
 import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
 import org.springframework.web.multipart.MultipartFile;
 import java.util.*;
@@ -51,6 +53,10 @@ public class LogPrintAop {
             Map<String, Object> logInfo = new LinkedHashMap<>(2);
             logInfo.put("version", VERSION);
+            ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
+            if (Objects.nonNull(attributes)) {
+                logInfo.put("uri", attributes.getRequest().getRequestURI());
+            }
             logInfo.put("method", className);
             logInfo.put("args", argsList);
             log.info("{}：{}", commonParamLogPrint.desc(), JsonUtils.toJsonString(logInfo));
 package com.diligrp.cashier.mall;
+import com.diligrp.cashier.shared.Constants;
+
 /**
  * 商城常量
  */
@@ -10,6 +12,6 @@ public interface MallConstants {
     Integer RT_MALL_SOURCE = 1;
-    String MALL_TOKEN = "mall_token:";
-    String MALL_USER_INFO = "mall_user_info:";
+    String MALL_TOKEN = Constants.PRODUCT_NAME + "mall_token:";
+    String MALL_USER_INFO = Constants.PRODUCT_NAME + "mall_user_info:";
 }
@@ -9,6 +9,7 @@ import com.diligrp.cashier.mall.domain.rtmall.vo.UserInfoVO;
 import com.diligrp.cashier.mall.exception.RtMartMallException;
 import com.diligrp.cashier.mall.sign.RtMallSign;
 import com.diligrp.cashier.mall.type.RtMarkErrorCode;
+import com.diligrp.cashier.mall.util.RtMallValidateUtils;
 import com.diligrp.cashier.shared.annotation.ParamLogPrint;
 import com.diligrp.cashier.shared.annotation.Sign;
 import com.diligrp.cashier.shared.domain.Message;
@@ -33,7 +34,7 @@ import java.util.Objects;
  * @Description MallAuthApi
  */
 @RestController
-@RequestMapping("/mall/auth")
+@RequestMapping(path = {"/mall", "/rt/mall"})
 @Validated
 public class MallAuthApi {
     private static final Logger log = LoggerFactory.getLogger(MallAuthApi.class);
@@ -43,10 +44,10 @@ public class MallAuthApi {
     /**
      * 获取授权连接
      */
-    @PostMapping("")
+    @PostMapping("/auth")
     @ParamLogPrint(outPrint = true)
     public Message<String> authLogin(@RequestBody @Valid AuthLoginCO authLogin) {
-        return Message.success(MallInitializeContext.getByChannel(authLogin.getChannel()).authLogin(authLogin));
+        return Message.success(MallInitializeContext.getBySource(authLogin.getSource()).authLogin(authLogin));
     }
     /**
@@ -57,12 +58,16 @@ public class MallAuthApi {
     @Sign(sign = RtMallSign.class)
     public RtMarkMessage<UserInfoVO> userInfo(@RequestBody @Valid Object req) {
         UserInfoCO userInfo = JsonUtils.convertValue(req, UserInfoCO.class);
+        RtMallValidateUtils.valid(userInfo);
+
+        // token认证
         Object cache = redisTemplate.opsForValue().get(MallConstants.MALL_TOKEN + userInfo.getToken());
         if (Objects.isNull(cache)) {
             throw new RtMartMallException(RtMarkErrorCode.E5001);
         }
+
         AuthLoginCO authLogin = JsonUtils.fromJsonString(Objects.requireNonNull(cache).toString(), AuthLoginCO.class);
-        UserInfoVO userInfoVO = MallInitializeContext.getByChannel(authLogin.getChannel()).userInfo(authLogin);
+        UserInfoVO userInfoVO = MallInitializeContext.getBySource(authLogin.getSource()).userInfo(authLogin);
         return RtMarkMessage.success(userInfoVO);
     }
 }
+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.vo.OrderPaymentVO;
+import com.diligrp.cashier.mall.domain.rtmall.vo.OrderSuccessVO;
+import com.diligrp.cashier.mall.service.biz.MallBizOrderService;
+import com.diligrp.cashier.mall.sign.RtMallSign;
+import com.diligrp.cashier.mall.util.RtMallValidateUtils;
+import com.diligrp.cashier.shared.annotation.ParamLogPrint;
+import com.diligrp.cashier.shared.annotation.RepeatSubmit;
+import com.diligrp.cashier.shared.annotation.Sign;
+import com.diligrp.cashier.shared.handler.duplication.SpelDuplicationSubmit;
+import com.diligrp.cashier.shared.util.JsonUtils;
+import jakarta.annotation.Resource;
+import jakarta.validation.Valid;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @ClassName RtMallOrderApi.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description RtMallOrderApi
+ * @date 2025-12-26 11:31
+ */
+@RestController
+@RequestMapping(path = {"/api/rt/mall", "/rt/mall"})
+@Validated
+public class RtMallOrderApi {
+    @Resource
+    private MallBizOrderService mallBizOrderService;
+
+    /**
+     * createOrder
+     * @see https://shopex.yuque.com/hl0rrx/vlp0m4/nkwt5yrhdfzoy78s?singleDoc#oJ2JC
+     * 创建订单接口
+     */
+    @PostMapping("/order/v1")
+    @ParamLogPrint(outPrint = true)
+    @Sign(sign = RtMallSign.class)
+    @RepeatSubmit(prefix = "order_sync:", value = "#req['order_id']", duplicationSubmit = SpelDuplicationSubmit.class)
+    public RtMarkMessage<OrderSuccessVO> createOrder(@Valid @RequestBody Object req) {
+        OrderCO orderCo = JsonUtils.convertValue(req, OrderCO.class);
+        RtMallValidateUtils.valid(orderCo);
+        return RtMarkMessage.success(mallBizOrderService.createOrder(orderCo));
+    }
+
+    /**
+     * info
+     * @see https://shopex.yuque.com/hl0rrx/vlp0m4/nkwt5yrhdfzoy78s?singleDoc#oJ2JC
+     * 查询订单状态
+     */
+    @PostMapping("/order/v1/info")
+    @ParamLogPrint(outPrint = true)
+    @Sign(sign = RtMallSign.class)
+    public RtMarkMessage<OrderPaymentVO> info(@Valid @RequestBody Object req) {
+        OrderInfoCO orderInfoCo = JsonUtils.convertValue(req, OrderInfoCO.class);
+        RtMallValidateUtils.valid(orderInfoCo);
+        return RtMarkMessage.success(mallBizOrderService.info(orderInfoCo));
+    }
+
+    /**
+     * 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();
+    }
+}
+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.sign.RtMallSign;
+import com.diligrp.cashier.mall.util.RtMallValidateUtils;
+import com.diligrp.cashier.shared.annotation.ParamLogPrint;
+import com.diligrp.cashier.shared.annotation.RepeatSubmit;
+import com.diligrp.cashier.shared.annotation.Sign;
+import com.diligrp.cashier.shared.handler.duplication.SpelDuplicationSubmit;
+import com.diligrp.cashier.shared.util.JsonUtils;
+import jakarta.annotation.Resource;
+import jakarta.validation.Valid;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @ClassName RtMallOrderRefundApi.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description RtMallOrderRefundApi
+ */
+@RestController
+@RequestMapping(path = {"/api/rt/mall", "/rt/mall"})
+@Validated
+public class RtMallOrderRefundApi {
+    @Resource
+    private MallBizOrderService mallBizOrderService;
+
+    /**
+     * createOrder
+     * @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));
+    }
+
+    /**
+     * info
+     * @see https://shopex.yuque.com/hl0rrx/vlp0m4/nkwt5yrhdfzoy78s?singleDoc#oJ2JC
+     * 查询订单状态
+     */
+    @PostMapping("/refund/v1/info")
+    @ParamLogPrint(outPrint = true)
+    @Sign(sign = RtMallSign.class)
+    public RtMarkMessage<?> info(@Valid @RequestBody Object req) {
+        OrderCO orderCo = JsonUtils.convertValue(req, OrderCO.class);
+        RtMallValidateUtils.valid(orderCo);
+        return RtMarkMessage.success();
+    }
+}
@@ -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<String, AbstractChannel> SOURCE_CHANNEL_MAP = Maps.newConcurrentMap();
+    public static Map<Integer, AbstractChannel> SOURCE_CHANNEL_MAP = Maps.newConcurrentMap();
     public static Map<Integer, AbstractPayChannel> PAY_CHANNEL_MAP = Maps.newConcurrentMap();
     /**
@@ -32,7 +32,7 @@ public class MallInitializeContext implements InitializingBean, DisposableBean {
     @Override
     public void afterPropertiesSet() throws Exception {
         SpringContextUtils.getBeanOfTpe(AbstractChannel.class).forEach((key, value) -> {
-            SOURCE_CHANNEL_MAP.put(value.channel(), value);
+            SOURCE_CHANNEL_MAP.put(value.source(), value);
         });
         SpringContextUtils.getBeanOfTpe(AbstractPayChannel.class).forEach((key, value) -> {
@@ -51,8 +51,8 @@ public class MallInitializeContext implements InitializingBean, DisposableBean {
     /**
      * getByType
      */
-    public static AbstractChannel getByChannel(String channel) {
-        return Optional.ofNullable(SOURCE_CHANNEL_MAP.get(channel)).orElseThrow(() -> new MallException("不支持该渠道！"));
+    public static AbstractChannel getBySource(Integer source) {
+        return Optional.ofNullable(SOURCE_CHANNEL_MAP.get(source)).orElseThrow(() -> new MallException("不支持该渠道！"));
     }
     /**
@@ -3,6 +3,11 @@ package com.diligrp.cashier.mall.dao;
 import com.diligrp.cashier.mall.model.MallBizOrderAddress;
 import com.diligrp.cashier.shared.mybatis.MybatisMapperSupport;
+/**
+ * MallBizOrderAddressDao
+ *
+ * @author dengwei
+ */
 public interface MallBizOrderAddressDao extends MybatisMapperSupport {
     int deleteByPrimaryKey(Long id);
@@ -7,6 +7,7 @@ import com.diligrp.cashier.shared.mybatis.MybatisMapperSupport;
 /**
  * MallBizOrderDao
  *
+ * @author dengwei
  */
 public interface MallBizOrderDao extends MybatisMapperSupport {
     int deleteByPrimaryKey(Long id);
@@ -3,7 +3,15 @@ package com.diligrp.cashier.mall.dao;
 import com.diligrp.cashier.mall.model.MallBizOrderItem;
 import com.diligrp.cashier.shared.mybatis.MybatisMapperSupport;
+import org.apache.ibatis.annotations.Param;
+import java.util.List;
+
+/**
+ * MallBizOrderItemDao
+ *
+ * @author dengwei
+ */
 public interface MallBizOrderItemDao extends MybatisMapperSupport {
     int deleteByPrimaryKey(Long id);
@@ -16,4 +24,6 @@ public interface MallBizOrderItemDao extends MybatisMapperSupport {
     int updateByPrimaryKeySelective(MallBizOrderItem record);
     int updateByPrimaryKey(MallBizOrderItem record);
+
+    void batchInsert(@Param("list") List<MallBizOrderItem> mallBizOrderItems);
 }
@@ -3,6 +3,11 @@ package com.diligrp.cashier.mall.dao;
 import com.diligrp.cashier.mall.model.MallBizPayment;
 import com.diligrp.cashier.shared.mybatis.MybatisMapperSupport;
+/**
+ * MallBizPaymentDao
+ *
+ * @author dengwei
+ */
 public interface MallBizPaymentDao extends MybatisMapperSupport {
     int deleteByPrimaryKey(Long id);
@@ -4,6 +4,11 @@ package com.diligrp.cashier.mall.dao;
 import com.diligrp.cashier.mall.model.MallBizRefundItem;
 import com.diligrp.cashier.shared.mybatis.MybatisMapperSupport;
+/**
+ * MallBizRefundItemDao
+ *
+ * @author dengwei
+ */
 public interface MallBizRefundItemDao extends MybatisMapperSupport {
     int deleteByPrimaryKey(Long id);
@@ -51,13 +51,14 @@ public class RtMarkMessage&lt;T&gt; {
     }
     public static RtMarkMessage<?> success() {
-        return failure(RtMarkErrorCode.E0000.getCode(), MallConstants.RESULT_SUCCESS);
+        return success(null);
     }
     public static <E> RtMarkMessage<E> success(E data) {
         RtMarkMessage<E> result = new RtMarkMessage<>();
         result.code = RtMarkErrorCode.E0000.getCode();
         result.result = MallConstants.RESULT_SUCCESS;
+        result.msg = RtMarkErrorCode.E0000.getMessage();
         result.data = data;
         return result;
     }
+package com.diligrp.cashier.mall.domain.rtmall.co;
+
+import com.diligrp.cashier.mall.domain.rtmall.RtMarkBaseCO;
+import com.diligrp.cashier.shared.jackson.deserializer.SecondToDateDeserializer;
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import jakarta.validation.Valid;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * @ClassName OrderCreateCO.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description OrderCO
+ * @date 2025-12-26 14:16
+ */
+public class OrderCO extends RtMarkBaseCO {
+    @NotBlank(message = "order_id is required")
+    private String orderId;
+
+    @NotBlank(message = "trade_id is required")
+    private String tradeId;
+
+    @NotBlank(message = "user_code is required")
+    private String userCode;
+
+    @NotNull(message = "order_time is required")
+    @JsonDeserialize(using = SecondToDateDeserializer.class)
+    private LocalDateTime orderTime;
+
+    @NotBlank(message = "company_code is required")
+    private String companyCode;
+
+    private Integer orderExpire;
+
+    @NotNull(message = "total_amount is required")
+    private Long totalAmount;
+
+    @NotNull(message = "freight_fee is required")
+    private Long freightFee;
+
+    @NotBlank(message = "shop_code is required")
+    private String shopCode;
+
+    @NotBlank(message = "shop_name is required")
+    private String shopName;
+
+    @Valid
+    private List<OrderItemCO> itemList;
+
+    private ReceiverInfoCO receiverInfo;
+
+    public String getOrderId() {
+        return orderId;
+    }
+
+    public void setOrderId(String orderId) {
+        this.orderId = orderId;
+    }
+
+    public String getTradeId() {
+        return tradeId;
+    }
+
+    public void setTradeId(String tradeId) {
+        this.tradeId = tradeId;
+    }
+
+    public String getUserCode() {
+        return userCode;
+    }
+
+    public void setUserCode(String userCode) {
+        this.userCode = userCode;
+    }
+
+    public LocalDateTime getOrderTime() {
+        return orderTime;
+    }
+
+    public void setOrderTime(LocalDateTime orderTime) {
+        this.orderTime = orderTime;
+    }
+
+    public String getCompanyCode() {
+        return companyCode;
+    }
+
+    public void setCompanyCode(String companyCode) {
+        this.companyCode = companyCode;
+    }
+
+    public Integer getOrderExpire() {
+        return orderExpire;
+    }
+
+    public void setOrderExpire(Integer orderExpire) {
+        this.orderExpire = orderExpire;
+    }
+
+    public Long getTotalAmount() {
+        return totalAmount;
+    }
+
+    public void setTotalAmount(Long totalAmount) {
+        this.totalAmount = totalAmount;
+    }
+
+    public Long getFreightFee() {
+        return freightFee;
+    }
+
+    public void setFreightFee(Long freightFee) {
+        this.freightFee = freightFee;
+    }
+
+    public String getShopCode() {
+        return shopCode;
+    }
+
+    public void setShopCode(String shopCode) {
+        this.shopCode = shopCode;
+    }
+
+    public String getShopName() {
+        return shopName;
+    }
+
+    public void setShopName(String shopName) {
+        this.shopName = shopName;
+    }
+
+    public List<OrderItemCO> getItemList() {
+        return itemList;
+    }
+
+    public void setItemList(List<OrderItemCO> itemList) {
+        this.itemList = itemList;
+    }
+
+    public ReceiverInfoCO getReceiverInfo() {
+        return receiverInfo;
+    }
+
+    public void setReceiverInfo(ReceiverInfoCO receiverInfo) {
+        this.receiverInfo = receiverInfo;
+    }
+}
+package com.diligrp.cashier.mall.domain.rtmall.co;
+
+import com.diligrp.cashier.mall.domain.rtmall.RtMarkBaseCO;
+import jakarta.validation.constraints.NotBlank;
+
+/**
+ * @ClassName OrderInfoCO.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description OrderInfoCO
+ */
+public class OrderInfoCO extends RtMarkBaseCO {
+    @NotBlank(message = "order_id is required")
+    private String orderId;
+
+    @NotBlank(message = "trade_id is required")
+    private String tradeId;
+
+    @NotBlank(message = "user_code is required")
+    private String userCode;
+
+    @NotBlank(message = "company_code is required")
+    private String companyCode;
+
+    public String getOrderId() {
+        return orderId;
+    }
+
+    public void setOrderId(String orderId) {
+        this.orderId = orderId;
+    }
+
+    public String getTradeId() {
+        return tradeId;
+    }
+
+    public void setTradeId(String tradeId) {
+        this.tradeId = tradeId;
+    }
+
+    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;
+    }
+}
+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 OrderItemCO.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description OrderItemCO
+ * @date 2025-12-26 14:20
+ */
+@JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
+public class OrderItemCO {
+    @NotNull(message = "num is required")
+    private Integer num;
+
+    private String pic;
+
+    @NotNull(message = "price is required")
+    private Long price;
+
+    @NotNull(message = "amount is required")
+    private Long amount;
+
+    @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;
+
+    private String taxOutputRate;
+
+    private String taxClassificationCode;
+
+    private String taxClassificationName;
+
+    public Integer getNum() {
+        return num;
+    }
+
+    public void setNum(Integer num) {
+        this.num = num;
+    }
+
+    public String getPic() {
+        return pic;
+    }
+
+    public void setPic(String pic) {
+        this.pic = pic;
+    }
+
+    public Long getPrice() {
+        return price;
+    }
+
+    public void setPrice(Long price) {
+        this.price = price;
+    }
+
+    public Long getAmount() {
+        return amount;
+    }
+
+    public void setAmount(Long amount) {
+        this.amount = amount;
+    }
+
+    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;
+    }
+
+    public String getTaxOutputRate() {
+        return taxOutputRate;
+    }
+
+    public void setTaxOutputRate(String taxOutputRate) {
+        this.taxOutputRate = taxOutputRate;
+    }
+
+    public String getTaxClassificationCode() {
+        return taxClassificationCode;
+    }
+
+    public void setTaxClassificationCode(String taxClassificationCode) {
+        this.taxClassificationCode = taxClassificationCode;
+    }
+
+    public String getTaxClassificationName() {
+        return taxClassificationName;
+    }
+
+    public void setTaxClassificationName(String taxClassificationName) {
+        this.taxClassificationName = taxClassificationName;
+    }
+}
+package com.diligrp.cashier.mall.domain.rtmall.co;
+
+import com.fasterxml.jackson.databind.PropertyNamingStrategies;
+import com.fasterxml.jackson.databind.annotation.JsonNaming;
+
+/**
+ * @ClassName ReceiverInfoCO.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description ReceiverInfoCO
+ * @date 2025-12-26 14:19
+ */
+@JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
+public class ReceiverInfoCO {
+    private String receiverName;
+    private String receiverMobile;
+    private String receiverAddress;
+
+    public String getReceiverName() {
+        return receiverName;
+    }
+
+    public void setReceiverName(String receiverName) {
+        this.receiverName = receiverName;
+    }
+
+    public String getReceiverMobile() {
+        return receiverMobile;
+    }
+
+    public void setReceiverMobile(String receiverMobile) {
+        this.receiverMobile = receiverMobile;
+    }
+
+    public String getReceiverAddress() {
+        return receiverAddress;
+    }
+
+    public void setReceiverAddress(String receiverAddress) {
+        this.receiverAddress = receiverAddress;
+    }
+}
+package com.diligrp.cashier.mall.domain.rtmall.vo;
+
+import com.fasterxml.jackson.databind.PropertyNamingStrategies;
+import com.fasterxml.jackson.databind.annotation.JsonNaming;
+
+/**
+ * @ClassName OrderPaymentVO.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description OrderPaymentVO
+ */
+@JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
+public class OrderPaymentVO {
+    /**
+     * 商户支付单号
+     */
+    private String outTradeNo;
+
+    /**
+     * 支付状态, 0:待支付,1:支付成功
+     * @see com.diligrp.cashier.mall.type.PayState
+     */
+    private String payStatus;
+
+    /**
+     * 支付金额,单位分
+     */
+    private String payFee;
+
+    /**
+     * 支付时间
+     */
+    private Long payTime;
+
+    /**
+     * 支付流水号(可为空, 支付成功时必传)
+     */
+    private String transactionId;
+
+    public String getOutTradeNo() {
+        return outTradeNo;
+    }
+
+    public void setOutTradeNo(String outTradeNo) {
+        this.outTradeNo = outTradeNo;
+    }
+
+    public String getPayStatus() {
+        return payStatus;
+    }
+
+    public void setPayStatus(String payStatus) {
+        this.payStatus = payStatus;
+    }
+
+    public String getPayFee() {
+        return payFee;
+    }
+
+    public void setPayFee(String payFee) {
+        this.payFee = payFee;
+    }
+
+    public Long getPayTime() {
+        return payTime;
+    }
+
+    public void setPayTime(Long payTime) {
+        this.payTime = payTime;
+    }
+
+    public String getTransactionId() {
+        return transactionId;
+    }
+
+    public void setTransactionId(String transactionId) {
+        this.transactionId = transactionId;
+    }
+}
+package com.diligrp.cashier.mall.domain.rtmall.vo;
+
+import com.fasterxml.jackson.databind.PropertyNamingStrategies;
+import com.fasterxml.jackson.databind.annotation.JsonNaming;
+
+/**
+ * @ClassName OrderSuccessVO.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description OrderSuccessVO
+ * @date 2025-12-26 14:13
+ */
+@JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
+public class OrderSuccessVO {
+    private String outTradeNo;
+    private String cashierUrl;
+
+    public OrderSuccessVO() {
+    }
+
+    public OrderSuccessVO(String outTradeNo, String cashierUrl) {
+        this.outTradeNo = outTradeNo;
+        this.cashierUrl = cashierUrl;
+    }
+
+    public String getOutTradeNo() {
+        return outTradeNo;
+    }
+
+    public void setOutTradeNo(String outTradeNo) {
+        this.outTradeNo = outTradeNo;
+    }
+
+    public String getCashierUrl() {
+        return cashierUrl;
+    }
+
+    public void setCashierUrl(String cashierUrl) {
+        this.cashierUrl = cashierUrl;
+    }
+}
 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.type.OrderState;
+import com.diligrp.cashier.mall.type.RtmartState;
+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 com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import org.springframework.beans.BeanUtils;
 import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Optional;
 /**
  * MallBizOrder
  *
+ * @author dengwei
  */
+@JsonIgnoreProperties({"version"})
 public class MallBizOrder extends BaseDO {
     /**
      * 订单单号-系统生成
@@ -84,15 +97,15 @@ public class MallBizOrder extends BaseDO {
     /**
      * 订单状态(0-notpay-未支付-1-payed-已支付 2-notpaycancel-未支付取消 3-payedcancel-已支付取消  4-done-订单完成 5-buyer_confirm-待用户收货)
-     * @see com.diligrp.cashier.mall.type.OrderStatus
+     * @see OrderState
      */
-    private Integer status;
+    private Integer state;
     /**
      * 配送状态(1-transfer-转单 2-package-打包 3-collect-揽件 4-delivery-配达)
-     * @see com.diligrp.cashier.mall.type.RtmartStatus
+     * @see RtmartState
      */
-    private Integer rtmartStatus;
+    private Integer rtmartState;
     /**
      * 下单时间
@@ -104,12 +117,19 @@ public class MallBizOrder extends BaseDO {
      */
     private Integer orderExpire;
+    /**
+     * 订单地址信息
+     */
+    private MallBizOrderAddress mallBizOrderAddress;
+
+    private List<MallBizOrderItem> mallBizOrderItems;
+
     public String getOrderNo() {
         return orderNo;
     }
     public void setOrderNo(String orderNo) {
-        this.orderNo = orderNo == null ? null : orderNo.trim();
+        this.orderNo = orderNo;
     }
     public String getOrderId() {
@@ -117,7 +137,7 @@ public class MallBizOrder extends BaseDO {
     }
     public void setOrderId(String orderId) {
-        this.orderId = orderId == null ? null : orderId.trim();
+        this.orderId = orderId;
     }
     public String getTradeId() {
@@ -125,7 +145,7 @@ public class MallBizOrder extends BaseDO {
     }
     public void setTradeId(String tradeId) {
-        this.tradeId = tradeId == null ? null : tradeId.trim();
+        this.tradeId = tradeId;
     }
     public String getChannel() {
@@ -133,7 +153,7 @@ public class MallBizOrder extends BaseDO {
     }
     public void setChannel(String channel) {
-        this.channel = channel == null ? null : channel.trim();
+        this.channel = channel;
     }
     public String getMchId() {
@@ -141,7 +161,23 @@ public class MallBizOrder extends BaseDO {
     }
     public void setMchId(String mchId) {
-        this.mchId = mchId == null ? null : mchId.trim();
+        this.mchId = mchId;
+    }
+
+    public Integer getSource() {
+        return source;
+    }
+
+    public void setSource(Integer source) {
+        this.source = source;
+    }
+
+    public Integer getOrderType() {
+        return orderType;
+    }
+
+    public void setOrderType(Integer orderType) {
+        this.orderType = orderType;
     }
     public String getUserCode() {
@@ -149,7 +185,7 @@ public class MallBizOrder extends BaseDO {
     }
     public void setUserCode(String userCode) {
-        this.userCode = userCode == null ? null : userCode.trim();
+        this.userCode = userCode;
     }
     public String getUsername() {
@@ -157,7 +193,7 @@ public class MallBizOrder extends BaseDO {
     }
     public void setUsername(String username) {
-        this.username = username == null ? null : username.trim();
+        this.username = username;
     }
     public String getCompanyCode() {
@@ -165,7 +201,7 @@ public class MallBizOrder extends BaseDO {
     }
     public void setCompanyCode(String companyCode) {
-        this.companyCode = companyCode == null ? null : companyCode.trim();
+        this.companyCode = companyCode;
     }
     public String getShopCode() {
@@ -173,7 +209,7 @@ public class MallBizOrder extends BaseDO {
     }
     public void setShopCode(String shopCode) {
-        this.shopCode = shopCode == null ? null : shopCode.trim();
+        this.shopCode = shopCode;
     }
     public String getShopName() {
@@ -181,7 +217,7 @@ public class MallBizOrder extends BaseDO {
     }
     public void setShopName(String shopName) {
-        this.shopName = shopName == null ? null : shopName.trim();
+        this.shopName = shopName;
     }
     public Long getTotalAmount() {
@@ -200,6 +236,22 @@ public class MallBizOrder extends BaseDO {
         this.freightFee = freightFee;
     }
+    public Integer getState() {
+        return state;
+    }
+
+    public void setState(Integer state) {
+        this.state = state;
+    }
+
+    public Integer getRtmartState() {
+        return rtmartState;
+    }
+
+    public void setRtmartState(Integer rtmartState) {
+        this.rtmartState = rtmartState;
+    }
+
     public LocalDateTime getOrderTime() {
         return orderTime;
     }
@@ -215,4 +267,64 @@ public class MallBizOrder extends BaseDO {
     public void setOrderExpire(Integer orderExpire) {
         this.orderExpire = orderExpire;
     }
+
+    public MallBizOrderAddress getMallBizOrderAddress() {
+        return mallBizOrderAddress;
+    }
+
+    public void setMallBizOrderAddress(MallBizOrderAddress mallBizOrderAddress) {
+        this.mallBizOrderAddress = mallBizOrderAddress;
+    }
+
+    public List<MallBizOrderItem> getMallBizOrderItems() {
+        return mallBizOrderItems;
+    }
+
+    public void setMallBizOrderItems(List<MallBizOrderItem> mallBizOrderItems) {
+        this.mallBizOrderItems = mallBizOrderItems;
+    }
+
+    /**
+     * of
+     */
+    public static MallBizOrder of(OrderCO orderCo, AuthLoginCO authLogin) {
+        orderCo.setVersion(null);
+        MallBizOrder mallBizOrder = new MallBizOrder();
+        BeanUtils.copyProperties(orderCo, mallBizOrder);
+
+        MallSnowflakeKeyManager snowflakeKeyManager = SpringContextUtils.getBean(MallSnowflakeKeyManager.class);
+        mallBizOrder.setId(snowflakeKeyManager.nextId(SnowflakeKey.MALL_BIZ_ORDER_ID));
+        mallBizOrder.setOrderNo(snowflakeKeyManager.nextId(SnowflakeKey.MALL_BIZ_ORDER_ID).toString());
+        BeanUtils.copyProperties(authLogin, mallBizOrder);
+
+        Optional.ofNullable(orderCo.getReceiverInfo())
+                .ifPresent(receiverInfo -> {
+                    MallBizOrderAddress address = new MallBizOrderAddress();
+                    mallBizOrder.setMallBizOrderAddress(address);
+
+                    address.setId(mallBizOrder.getId());
+                    address.setReceiverName(receiverInfo.getReceiverName());
+                    address.setReceiverMobile(receiverInfo.getReceiverMobile());
+                    address.setReceiverAddress(receiverInfo.getReceiverAddress());
+                });
+
+        Optional.ofNullable(orderCo.getItemList())
+                .ifPresent(itemList -> {
+                    List<MallBizOrderItem> orderItems = itemList
+                            .stream()
+                            .map(itemCo -> {
+                                MallBizOrderItem item = new MallBizOrderItem();
+                                BeanUtils.copyProperties(itemCo, item);
+
+                                item.setId(snowflakeKeyManager.nextId(SnowflakeKey.MALL_BIZ_ORDER_ID));
+                                item.setBizOrderId(mallBizOrder.getId());
+                                item.setOrderId(orderCo.getOrderId());
+                                item.setShopCode(orderCo.getShopCode());
+                                item.setShopName(orderCo.getShopName());
+                                return item;
+                            }).toList();
+                    mallBizOrder.setMallBizOrderItems(orderItems);
+                });
+        return mallBizOrder;
+    }
 }
@@ -21,7 +21,7 @@ public class MallBizOrderItem extends BaseDO {
     /**
      * 业务侧子订单号
      */
-    private String subOrderId;
+    private Long subOrderId;
     /**
      * 店铺编码
@@ -94,12 +94,12 @@ public class MallBizOrderItem extends BaseDO {
         this.orderId = orderId == null ? null : orderId.trim();
     }
-    public String getSubOrderId() {
+    public Long getSubOrderId() {
         return subOrderId;
     }
-    public void setSubOrderId(String subOrderId) {
-        this.subOrderId = subOrderId == null ? null : subOrderId.trim();
+    public void setSubOrderId(Long subOrderId) {
+        this.subOrderId = subOrderId;
     }
     public String getShopCode() {
 package com.diligrp.cashier.mall.model;
+import com.diligrp.cashier.mall.domain.rtmall.co.OrderCO;
+import com.diligrp.cashier.mall.property.MallDynamicProperty;
+import com.diligrp.cashier.mall.property.RtMallDynamicProperty;
+import com.diligrp.cashier.mall.type.PayState;
+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 java.time.LocalDateTime;
@@ -72,9 +79,9 @@ public class MallBizPayment extends BaseDO {
     /**
      * 支付状态
-     * @see com.diligrp.cashier.mall.type.PayStatus
+     * @see PayState
      */
-    private Integer payStatus;
+    private Integer payState;
     /**
      * dili支付成功时间
@@ -96,6 +103,29 @@ public class MallBizPayment extends BaseDO {
      */
     private String paymentCallback;
+    public static MallBizPayment of(final OrderCO orderCo,
+                                    final MallBizOrder mallBizOrder) {
+        MallSnowflakeKeyManager snowflakeKeyManager = SpringContextUtils.getBean(MallSnowflakeKeyManager.class);
+
+        MallBizPayment mallBizPayment = new MallBizPayment();
+        mallBizPayment.setId(snowflakeKeyManager.nextId(SnowflakeKey.MALL_BIZ_PAYMENT_ID));
+        mallBizPayment.setPayTradeNo(snowflakeKeyManager.nextId(SnowflakeKey.MALL_BIZ_PAYMENT_ID).toString());
+        mallBizPayment.setBizOrderId(mallBizOrder.getId());
+        mallBizPayment.setOrderId(orderCo.getOrderId());
+        mallBizPayment.setTradeId(orderCo.getTradeId());
+        mallBizPayment.setPayFee(orderCo.getTotalAmount());
+
+        // TODO 2025/12/29: 支付信息
+        mallBizPayment.setPayPaymentId("6666666666");
+        String cashierUrl = SpringContextUtils.getBean(MallDynamicProperty.class).getUrl();
+        mallBizPayment.setCashierUrl(cashierUrl.concat("?payTradeNo=").concat(mallBizPayment.getPayTradeNo()));
+
+        RtMallDynamicProperty rtMallDynamicProperty = SpringContextUtils.getBean(RtMallDynamicProperty.class);
+        RtMallDynamicProperty.AppSecretDynamicProperty property = rtMallDynamicProperty.getBySourceAndType(mallBizOrder.getSource(), mallBizOrder.getOrderType());
+        mallBizPayment.setPaymentCallback(property.getCallbackDomain());
+        return mallBizPayment;
+    }
+
     public String getPayTradeNo() {
         return payTradeNo;
     }
@@ -192,12 +222,12 @@ public class MallBizPayment extends BaseDO {
         this.payFee = payFee;
     }
-    public Integer getPayStatus() {
-        return payStatus;
+    public Integer getPayState() {
+        return payState;
     }
-    public void setPayStatus(Integer payStatus) {
-        this.payStatus = payStatus;
+    public void setPayState(Integer payState) {
+        this.payState = payState;
     }
     public LocalDateTime getPayTime() {
 package com.diligrp.cashier.mall.model;
+import com.diligrp.cashier.mall.type.RefundState;
 import com.diligrp.cashier.shared.domain.BaseDO;
 import java.time.LocalDateTime;
@@ -82,9 +83,9 @@ public class MallBizRefund extends BaseDO {
     /**
      * 退款状态
-     * @see com.diligrp.cashier.mall.type.RefundStatus
+     * @see RefundState
      */
-    private Integer refundStatus;
+    private Integer refundState;
     /**
      * 退款原因
@@ -213,12 +214,12 @@ public class MallBizRefund extends BaseDO {
         this.freightFee = freightFee;
     }
-    public Integer getRefundStatus() {
-        return refundStatus;
+    public Integer getRefundState() {
+        return refundState;
     }
-    public void setRefundStatus(Integer refundStatus) {
-        this.refundStatus = refundStatus;
+    public void setRefundState(Integer refundState) {
+        this.refundState = refundState;
     }
     public String getRefundReason() {
+package com.diligrp.cashier.mall.property;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @ClassName MallDynamicProperty.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description MallDynamicProperty
+ * @date 2025-12-29 16:42
+ */
+@Configuration
+@RefreshScope
+@ConfigurationProperties(prefix = "cashier.cash")
+public class MallDynamicProperty {
+    /**
+     * 收银台URL
+     */
+    @Value("${url:}")
+    private String url;
+
+    public String getUrl() {
+        return url;
+    }
+
+    public void setUrl(String url) {
+        this.url = url;
+    }
+}
 package com.diligrp.cashier.mall.property;
+import com.diligrp.cashier.mall.exception.RtMartMallException;
+import com.diligrp.cashier.mall.type.RtMarkErrorCode;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.cloud.context.config.annotation.RefreshScope;
@@ -19,6 +21,8 @@ import java.util.Optional;
 @RefreshScope
 @ConfigurationProperties(prefix = "rtmall.sign")
 public class RtMallDynamicProperty {
+    @Value("${domain:}")
+    private String domain;
     private List<AppSecretDynamicProperty> appSecrets;
@@ -41,6 +45,9 @@ public class RtMallDynamicProperty {
         @Value("${authUrl:https://hourh5-em-shop.feiniugo.com}")
         private String authUrl;
+        @Value("${callbackDomain:}")
+        private String callbackDomain;
+
         public Integer getSource() {
             return source;
         }
@@ -88,6 +95,22 @@ public class RtMallDynamicProperty {
         public void setCompanyCode(String companyCode) {
             this.companyCode = companyCode;
         }
+
+        public String getCallbackDomain() {
+            return callbackDomain;
+        }
+
+        public void setCallbackDomain(String callbackDomain) {
+            this.callbackDomain = callbackDomain;
+        }
+    }
+
+    public String getDomain() {
+        return domain;
+    }
+
+    public void setDomain(String domain) {
+        this.domain = domain;
     }
     public List<AppSecretDynamicProperty> getAppSecrets() {
@@ -121,7 +144,7 @@ public class RtMallDynamicProperty {
                 .stream()
                 .filter(item -> item.getSource().equals(source) && item.getOrderType().equals(orderType))
                 .findFirst()
-                .orElse(null);
+                .orElseThrow(() -> new RtMartMallException(RtMarkErrorCode.E5002));
     }
     /**
+package com.diligrp.cashier.mall.service.biz;
+
+/**
+ * @ClassName MallBizOrderItemService.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description MallBizOrderItemService
+ * @date 2025-12-26 14:44
+ */
+public interface MallBizOrderItemService {
+}
+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.vo.OrderPaymentVO;
+import com.diligrp.cashier.mall.domain.rtmall.vo.OrderSuccessVO;
+
+/**
+ * @ClassName MallBizOrderService.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description MallBizOrderService
+ * @date 2025-12-26 14:42
+ */
+public interface MallBizOrderService {
+    /**
+     * createOrder
+     */
+    OrderSuccessVO createOrder(OrderCO orderCo);
+
+    /**
+     * info
+     */
+    OrderPaymentVO info(OrderInfoCO orderInfoCo);
+}
+package com.diligrp.cashier.mall.service.biz;
+
+import com.diligrp.cashier.mall.model.MallBizPayment;
+
+/**
+ * @ClassName MallBizPaymentService.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description MallBizPaymentService
+ * @date 2025-12-26 14:46
+ */
+public interface MallBizPaymentService {
+    void save(MallBizPayment mallBizPayment);
+}
+package com.diligrp.cashier.mall.service.biz.impl;
+
+import com.diligrp.cashier.mall.service.biz.MallBizOrderItemService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+
+/**
+ * @ClassName MallBizOrderItemServiceImpl.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description MallBizOrderItemServiceImpl
+ * @date 2025-12-26 14:44
+ */
+@Service
+public class MallBizOrderItemServiceImpl implements MallBizOrderItemService {
+    private static final Logger log = LoggerFactory.getLogger(MallBizOrderItemServiceImpl.class);
+
+}
+package com.diligrp.cashier.mall.service.biz.impl;
+
+import com.diligrp.cashier.mall.MallConstants;
+import com.diligrp.cashier.mall.dao.MallBizOrderAddressDao;
+import com.diligrp.cashier.mall.dao.MallBizOrderDao;
+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.vo.OrderPaymentVO;
+import com.diligrp.cashier.mall.domain.rtmall.vo.OrderSuccessVO;
+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.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.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Objects;
+import java.util.Optional;
+
+/**
+ * @ClassName MallBizOrderServiceImpl.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description MallBizOrderServiceImpl
+ * @date 2025-12-26 14:42
+ */
+@Service
+public class MallBizOrderServiceImpl implements MallBizOrderService {
+    private static final Logger log = LoggerFactory.getLogger(MallBizOrderServiceImpl.class);
+
+    @Resource
+    private RedisTemplate<String, Object> redisTemplate;
+    @Resource
+    private MallSnowflakeKeyManager mallSnowflakeKeyManager;
+    @Resource
+    private MallBizPaymentService mallBizPaymentService;
+    @Resource
+    private MallBizOrderDao mallBizOrderDao;
+    @Resource
+    private MallBizOrderAddressDao mallBizOrderAddressDao;
+    @Resource
+    private MallBizOrderItemDao mallBizOrderItemDao;
+
+    /**
+     * createOrder
+     *
+     */
+    @Override
+    @Transactional(rollbackFor = {Exception.class})
+    public OrderSuccessVO createOrder(OrderCO orderCo) {
+        AuthLoginCO authLogin = getAuthLogin(orderCo.getUserCode());
+
+        // order
+        MallBizOrder mallBizOrder = MallBizOrder.of(orderCo, authLogin);
+
+        // payment
+        MallBizPayment mallBizPayment = MallBizPayment.of(orderCo, mallBizOrder);
+
+        // save
+        commonCreate(mallBizOrder, mallBizPayment);
+        return new OrderSuccessVO(mallSnowflakeKeyManager.nextId(SnowflakeKey.MALL_BIZ_ORDER_ID).toString(), "https://www.baidu.com");
+    }
+
+    /**
+     * info
+     *
+     */
+    @Override
+    public OrderPaymentVO info(OrderInfoCO orderInfoCo) {
+        return null;
+    }
+
+    /**
+     * getAuthLogin
+     */
+    private AuthLoginCO getAuthLogin(String userCode) {
+        Object cache = redisTemplate.opsForValue().get(MallConstants.MALL_USER_INFO + userCode);
+        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;
+    }
+
+    /**
+     * commonCreate
+     *
+     */
+    public void commonCreate(MallBizOrder mallBizOrder, MallBizPayment mallBizPayment) {
+        mallBizOrderDao.insertSelective(mallBizOrder);
+        Optional.ofNullable(mallBizOrder.getMallBizOrderAddress())
+                .ifPresent(mallBizOrderAddress -> {
+                    mallBizOrderAddressDao.insertSelective(mallBizOrderAddress);
+                });
+
+        Optional.ofNullable(mallBizOrder.getMallBizOrderItems()).ifPresent(mallBizOrderItems -> {
+            mallBizOrderItemDao.batchInsert(mallBizOrderItems);
+        });
+
+        Optional.ofNullable(mallBizPayment).ifPresent(mallBizPaymentService::save);
+    }
+}
+package com.diligrp.cashier.mall.service.biz.impl;
+
+import com.diligrp.cashier.mall.dao.MallBizPaymentDao;
+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.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * @ClassName MallBizPaymentServiceImpl.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description MallBizPaymentServiceImpl
+ * @date 2025-12-26 14:47
+ */
+@Service
+public class MallBizPaymentServiceImpl implements MallBizPaymentService {
+    private static final Logger log = LoggerFactory.getLogger(MallBizPaymentServiceImpl.class);
+
+    @Resource
+    private MallBizPaymentDao mallBizPaymentDao;
+
+    @Override
+    @Transactional(rollbackFor = {Exception.class})
+    public void save(MallBizPayment mallBizPayment) {
+        mallBizPaymentDao.insertSelective(mallBizPayment);
+    }
+}
@@ -67,7 +67,7 @@ public abstract class AbstractChannel {
     /**
      * 渠道
      */
-    public abstract String channel();
+    public abstract Integer source();
     /**
      * authLoginUrl
@@ -3,7 +3,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.property.RtMallDynamicProperty;
-import com.diligrp.cashier.mall.type.OrderChannel;
+import com.diligrp.cashier.mall.type.OrderSource;
 import com.diligrp.cashier.mall.util.RtMallSignMd5Utils;
 import com.diligrp.cashier.shared.util.JsonUtils;
 import com.diligrp.cashier.shared.util.UrlParamParserUtils;
@@ -55,7 +55,7 @@ public class RtMallChannel extends AbstractChannel {
     }
     @Override
-    public String channel() {
-        return OrderChannel.RT_MART.getCode();
+    public Integer source() {
+        return OrderSource.RT_MART.getCode();
     }
 }
@@ -30,7 +30,7 @@ public class RtMallSign implements SecuritySign {
     private static final Logger log = LoggerFactory.getLogger(RtMallSign.class);
     @Resource
-    private RtMallDynamicProperty mallDynamicProperty;
+    private RtMallDynamicProperty rtMallDynamicProperty;
     @Override
     public void sign(HttpServletRequest request, HttpServletResponse response, Object data) {
@@ -50,7 +50,7 @@ public class RtMallSign implements SecuritySign {
         }
         paramMap.remove("sign");
-        RtMallDynamicProperty.AppSecretDynamicProperty property = mallDynamicProperty.getByAppKey(appKey.toString());
+        RtMallDynamicProperty.AppSecretDynamicProperty property = rtMallDynamicProperty.getByAppKey(appKey.toString());
         if (Objects.isNull(property)) {
             throw new RtMartMallException(RtMarkErrorCode.E4003);
         }
@@ -8,8 +8,8 @@ package com.diligrp.cashier.mall.type;
  * @date 2025-12-25 11:18
  */
 public enum OrderChannel {
-    RT_MART("1", "大润发"),
-    SAM("2", "山姆");
+    RT_MART("1", "中瑞"),
+    SAM("2", "地利");
     public final String code;
     public final String description;
@@ -6,7 +6,7 @@ package com.diligrp.cashier.mall.type;
  * @version 1.0.0
  * @Description OrderStatus
  */
-public enum OrderStatus {
+public enum OrderState {
     NOT_PAY(0, "notpay", "未支付"),
     PAYED(1, "payed", "已支付"),
     NOT_PAY_CANCEL(2, "notpaycancel", "未支付取消"),
@@ -19,7 +19,7 @@ public enum OrderStatus {
     public final String key;
     public final String name;
-    OrderStatus(int code, String key, String name) {
+    OrderState(int code, String key, String name) {
         this.code = code;
         this.key = key;
         this.name = name;
@@ -7,7 +7,7 @@ package com.diligrp.cashier.mall.type;
  * @Description PayStatus
  * @date 2025-12-26 11:01
  */
-public enum PayStatus {
+public enum PayState {
     PENDING(0, "待支付"),
     SUCCESS(1, "成功"),
     FAILED(2, "失败"),
@@ -16,7 +16,7 @@ public enum PayStatus {
     public final int code;
     public final String description;
-    PayStatus(int code, String description) {
+    PayState(int code, String description) {
         this.code = code;
         this.description = description;
     }
@@ -7,7 +7,7 @@ package com.diligrp.cashier.mall.type;
  * @Description RefundStatus
  * @date 2025-12-26 11:08
  */
-public enum RefundStatus {
+public enum RefundState {
     PENDING(0, "待退款"),
     SUCCESS(1, "成功"),
     FAILED(2, "失败"),
@@ -16,7 +16,7 @@ public enum RefundStatus {
     public final int code;
     public final String description;
-    RefundStatus(int code, String description) {
+    RefundState(int code, String description) {
         this.code = code;
         this.description = description;
     }
@@ -13,8 +13,11 @@ public enum RtMarkErrorCode {
     E4002("E4002", "timestamp 不合法"),
     E4003("E4003", "app_key 错误"),
     E4004("E4004", "签名错误"),
+    E4005("E4005", "参数异常"),
     E5000("E5000", "未知错误"),
-    E5001("E5001", "认证失败");
+    E5001("E5001", "认证失败"),
+    E5002("E5002", "不支持的类型"),
+    ;
     public final String code;
     public final String message;
@@ -7,7 +7,7 @@ package com.diligrp.cashier.mall.type;
  * @Description RtmartStatus
  * @date 2025-12-26 10:03
  */
-public enum RtmartStatus {
+public enum RtmartState {
     TRANSFER(1, "transfer", "转单"),
     PACKAGE(2, "package", "打包"),
     COLLECT(3, "collect", "揽件"),
@@ -18,7 +18,7 @@ public enum RtmartStatus {
     public final String key;
     public final String name;
-    RtmartStatus(int code, String key, String name) {
+    RtmartState(int code, String key, String name) {
         this.code = code;
         this.key = key;
         this.name = name;
+package com.diligrp.cashier.mall.util;
+
+import com.diligrp.cashier.assistant.service.impl.SnowflakeKeyManager;
+import com.diligrp.cashier.trade.type.SnowflakeKey;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Component;
+
+/**
+ * @ClassName MallSnowflakeKeyManager.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description MallSnowflakeKeyManager
+ * @date 2025-12-26 16:46
+ */
+@Component
+public class MallSnowflakeKeyManager {
+    @Resource
+    private SnowflakeKeyManager snowflakeKeyManager;
+
+    public Long nextId(SnowflakeKey snowflakeKey) {
+        return Long.valueOf(snowflakeKeyManager.getKeyGenerator(snowflakeKey).nextId());
+    }
+}
+package com.diligrp.cashier.mall.util;
+
+import com.diligrp.cashier.mall.exception.RtMartMallException;
+import com.diligrp.cashier.mall.type.RtMarkErrorCode;
+import com.diligrp.cashier.shared.util.ValidateUtils;
+
+/**
+ * @ClassName RtMallValidateUtils.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description RtMallValidateUtils
+ * @date 2025-12-26 15:14
+ */
+public class RtMallValidateUtils {
+    public static <T> void valid(T t) {
+        ValidateUtils.valid(t, (msg) -> {
+            throw new RtMartMallException(RtMarkErrorCode.E4005.getCode(), msg);
+        });
+    }
+}
@@ -17,8 +17,8 @@
     <result column="shop_name" jdbcType="VARCHAR" property="shopName" />
     <result column="total_amount" jdbcType="BIGINT" property="totalAmount" />
     <result column="freight_fee" jdbcType="BIGINT" property="freightFee" />
-    <result column="status" jdbcType="TINYINT" property="status" />
-    <result column="rtmart_status" jdbcType="TINYINT" property="rtmartStatus" />
+    <result column="state" jdbcType="TINYINT" property="state" />
+    <result column="rtmart_state" jdbcType="TINYINT" property="rtmartState" />
     <result column="order_time" jdbcType="TIMESTAMP" property="orderTime" />
     <result column="order_expire" jdbcType="INTEGER" property="orderExpire" />
     <result column="version" jdbcType="INTEGER" property="version" />
@@ -27,8 +27,8 @@
   </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, status,
-    rtmart_status, order_time, order_expire, version, created_time, modified_time
+    username, company_code, shop_code, shop_name, total_amount, freight_fee, state,
+    rtmart_state, order_time, order_expire, version, created_time, modified_time
   </sql>
   <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
     select
@@ -46,7 +46,7 @@
       source, order_type, user_code,
       username, company_code, shop_code,
       shop_name, total_amount, freight_fee,
-      status, rtmart_status, order_time,
+      state, rtmart_state, order_time,
       order_expire, version, created_time,
       modified_time)
     values (#{id,jdbcType=BIGINT}, #{orderNo,jdbcType=VARCHAR}, #{orderId,jdbcType=VARCHAR},
@@ -54,7 +54,7 @@
       #{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},
-      #{status,jdbcType=TINYINT}, #{rtmartStatus,jdbcType=TINYINT}, #{orderTime,jdbcType=TIMESTAMP},
+      #{state,jdbcType=TINYINT}, #{rtmartState,jdbcType=TINYINT}, #{orderTime,jdbcType=TIMESTAMP},
       #{orderExpire,jdbcType=INTEGER}, #{version,jdbcType=INTEGER}, #{createdTime,jdbcType=TIMESTAMP},
       #{modifiedTime,jdbcType=TIMESTAMP})
   </insert>
@@ -106,11 +106,11 @@
       <if test="freightFee != null">
         freight_fee,
       </if>
-      <if test="status != null">
-        status,
+      <if test="state != null">
+        state,
       </if>
-      <if test="rtmartStatus != null">
-        rtmart_status,
+      <if test="rtmartState != null">
+        rtmart_state,
       </if>
       <if test="orderTime != null">
         order_time,
@@ -174,11 +174,11 @@
       <if test="freightFee != null">
         #{freightFee,jdbcType=BIGINT},
       </if>
-      <if test="status != null">
-        #{status,jdbcType=TINYINT},
+      <if test="state != null">
+        #{state,jdbcType=TINYINT},
       </if>
-      <if test="rtmartStatus != null">
-        #{rtmartStatus,jdbcType=TINYINT},
+      <if test="rtmartState != null">
+        #{rtmartState,jdbcType=TINYINT},
       </if>
       <if test="orderTime != null">
         #{orderTime,jdbcType=TIMESTAMP},
@@ -242,11 +242,11 @@
       <if test="freightFee != null">
         freight_fee = #{freightFee,jdbcType=BIGINT},
       </if>
-      <if test="status != null">
-        status = #{status,jdbcType=TINYINT},
+      <if test="state != null">
+        state = #{state,jdbcType=TINYINT},
       </if>
-      <if test="rtmartStatus != null">
-        rtmart_status = #{rtmartStatus,jdbcType=TINYINT},
+      <if test="rtmartState != null">
+        rtmart_state = #{rtmartState,jdbcType=TINYINT},
       </if>
       <if test="orderTime != null">
         order_time = #{orderTime,jdbcType=TIMESTAMP},
@@ -282,8 +282,8 @@
       shop_name = #{shopName,jdbcType=VARCHAR},
       total_amount = #{totalAmount,jdbcType=BIGINT},
       freight_fee = #{freightFee,jdbcType=BIGINT},
-      status = #{status,jdbcType=TINYINT},
-      rtmart_status = #{rtmartStatus,jdbcType=TINYINT},
+      state = #{state,jdbcType=TINYINT},
+      rtmart_state = #{rtmartState,jdbcType=TINYINT},
       order_time = #{orderTime,jdbcType=TIMESTAMP},
       order_expire = #{orderExpire,jdbcType=INTEGER},
       version = #{version,jdbcType=INTEGER},
@@ -143,7 +143,7 @@
       </if>
     </trim>
   </insert>
-  <update id="updateByPrimaryKeySelective" parameterType="com.diligrp.cashier.mall.model.MallBizOrderItem">
+    <update id="updateByPrimaryKeySelective" parameterType="com.diligrp.cashier.mall.model.MallBizOrderItem">
     update mall_biz_order_item
     <set>
       <if test="bizOrderId != null">
@@ -209,4 +209,41 @@
       tax_classification_name = #{taxClassificationName,jdbcType=VARCHAR}
     where id = #{id,jdbcType=BIGINT}
   </update>
+
+    <insert id="batchInsert">
+      insert into mall_biz_order_item (
+        id,
+        biz_order_id,
+        order_id,
+        sub_order_id,
+        shop_code,
+        shop_name,
+        item_bn,
+        item_name,
+        num,
+        price,
+        amount,
+        pic,
+        tax_output_rate,
+        tax_classification_code,
+        tax_classification_name)
+      values
+      <foreach collection="list" item="item" separator=",">
+        (#{item.id,jdbcType=BIGINT},
+        #{item.bizOrderId,jdbcType=BIGINT},
+        #{item.orderId,jdbcType=VARCHAR},
+        #{item.subOrderId,jdbcType=VARCHAR},
+        #{item.shopCode,jdbcType=VARCHAR},
+        #{item.shopName,jdbcType=VARCHAR},
+        #{item.itemBn,jdbcType=VARCHAR},
+        #{item.itemName,jdbcType=VARCHAR},
+        #{item.num,jdbcType=INTEGER},
+        #{item.price,jdbcType=BIGINT},
+        #{item.amount,jdbcType=BIGINT},
+        #{item.pic,jdbcType=VARCHAR},
+        #{item.taxOutputRate,jdbcType=VARCHAR},
+        #{item.taxClassificationCode,jdbcType=VARCHAR},
+        #{item.taxClassificationName,jdbcType=VARCHAR})
+      </foreach>
+    </insert>
 </mapper>
@@ -15,7 +15,7 @@
     <result column="account_id" jdbcType="BIGINT" property="accountId" />
     <result column="fund_account_id" jdbcType="BIGINT" property="fundAccountId" />
     <result column="pay_fee" jdbcType="BIGINT" property="payFee" />
-    <result column="pay_status" jdbcType="TINYINT" property="payStatus" />
+    <result column="pay_state" jdbcType="TINYINT" property="payState" />
     <result column="pay_time" jdbcType="TIMESTAMP" property="payTime" />
     <result column="channel_id" jdbcType="TINYINT" property="channelId" />
     <result column="cashier_url" jdbcType="VARCHAR" property="cashierUrl" />
@@ -26,7 +26,7 @@
   </resultMap>
   <sql id="Base_Column_List">
     id, pay_trade_no, biz_order_id, order_id, trade_id, pay_payment_id, mch_id, card_no,
-    username, user_id, account_id, fund_account_id, pay_fee, pay_status, pay_time, channel_id,
+    username, user_id, account_id, fund_account_id, pay_fee, pay_state, pay_time, channel_id,
     cashier_url, payment_callback, version, created_time, modified_time
   </sql>
   <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
@@ -44,7 +44,7 @@
       order_id, trade_id, pay_payment_id,
       mch_id, card_no, username,
       user_id, account_id, fund_account_id,
-      pay_fee, pay_status, pay_time,
+      pay_fee, pay_state, pay_time,
       channel_id, cashier_url, payment_callback,
       version, created_time, modified_time
       )
@@ -52,7 +52,7 @@
       #{orderId,jdbcType=VARCHAR}, #{tradeId,jdbcType=VARCHAR}, #{payPaymentId,jdbcType=VARCHAR},
       #{mchId,jdbcType=VARCHAR}, #{cardNo,jdbcType=VARCHAR}, #{username,jdbcType=VARCHAR},
       #{userId,jdbcType=BIGINT}, #{accountId,jdbcType=BIGINT}, #{fundAccountId,jdbcType=BIGINT},
-      #{payFee,jdbcType=BIGINT}, #{payStatus,jdbcType=TINYINT}, #{payTime,jdbcType=TIMESTAMP},
+      #{payFee,jdbcType=BIGINT}, #{payState,jdbcType=TINYINT}, #{payTime,jdbcType=TIMESTAMP},
       #{channelId,jdbcType=TINYINT}, #{cashierUrl,jdbcType=VARCHAR}, #{paymentCallback,jdbcType=VARCHAR},
       #{version,jdbcType=INTEGER}, #{createdTime,jdbcType=TIMESTAMP}, #{modifiedTime,jdbcType=TIMESTAMP}
       )
@@ -99,8 +99,8 @@
       <if test="payFee != null">
         pay_fee,
       </if>
-      <if test="payStatus != null">
-        pay_status,
+      <if test="payState != null">
+        pay_state,
       </if>
       <if test="payTime != null">
         pay_time,
@@ -164,8 +164,8 @@
       <if test="payFee != null">
         #{payFee,jdbcType=BIGINT},
       </if>
-      <if test="payStatus != null">
-        #{payStatus,jdbcType=TINYINT},
+      <if test="payState != null">
+        #{payState,jdbcType=TINYINT},
       </if>
       <if test="payTime != null">
         #{payTime,jdbcType=TIMESTAMP},
@@ -229,8 +229,8 @@
       <if test="payFee != null">
         pay_fee = #{payFee,jdbcType=BIGINT},
       </if>
-      <if test="payStatus != null">
-        pay_status = #{payStatus,jdbcType=TINYINT},
+      <if test="payState != null">
+        pay_state = #{payState,jdbcType=TINYINT},
       </if>
       <if test="payTime != null">
         pay_time = #{payTime,jdbcType=TIMESTAMP},
@@ -270,7 +270,7 @@
       account_id = #{accountId,jdbcType=BIGINT},
       fund_account_id = #{fundAccountId,jdbcType=BIGINT},
       pay_fee = #{payFee,jdbcType=BIGINT},
-      pay_status = #{payStatus,jdbcType=TINYINT},
+      pay_state = #{payState,jdbcType=TINYINT},
       pay_time = #{payTime,jdbcType=TIMESTAMP},
       channel_id = #{channelId,jdbcType=TINYINT},
       cashier_url = #{cashierUrl,jdbcType=VARCHAR},
@@ -14,4 +14,6 @@ public final class Constants {
     public static final int MAX_POOL_SIZE = 200;
     public final static String CONTENT_TYPE = "application/json;charset=UTF-8";
-}
 \ No newline at end of file
+
+    public final static String PRODUCT_NAME = "cashier:";
+}
@@ -71,6 +71,6 @@ public class RepeatSubmitAop {
      */
     @AfterThrowing(value = "@annotation(repeatSubmit)", throwing = "e")
     public void doAfterThrowing(JoinPoint joinPoint, RepeatSubmit repeatSubmit, Exception e) {
-        log.error("repeat submit aspect after throwing");
+        log.error("business handler exception");
     }
 }
+package com.diligrp.cashier.shared.util;
+
+import jakarta.validation.ConstraintViolation;
+import jakarta.validation.Validation;
+import jakarta.validation.Validator;
+import jakarta.validation.ValidatorFactory;
+import org.apache.commons.lang3.StringUtils;
+
+import java.util.List;
+import java.util.Set;
+import java.util.function.Consumer;
+
+/**
+ * @ClassName ValidateUtils.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description ValidateUtils
+ * @date 2025-12-26 15:00
+ */
+public class ValidateUtils {
+    private static final Validator VALIDATOR;
+
+    static {
+        ValidatorFactory factory = Validation.buildDefaultValidatorFactory();
+        VALIDATOR = factory.getValidator();
+    }
+
+    /**
+     * 校验器
+     */
+    public static <T> void valid(T t, Consumer<String> consumer) {
+        Set<ConstraintViolation<T>> errors = VALIDATOR.validate(t);
+        List<String> msg = errors.stream().map(ConstraintViolation::getMessage).toList();
+        if (!msg.isEmpty()) {
+            consumer.accept(StringUtils.join(msg, "、"));
+        }
+    }
+}
@@ -4,6 +4,9 @@ import com.diligrp.cashier.assistant.service.impl.SnowflakeKeyManager;
 public enum SnowflakeKey implements SnowflakeKeyManager.SnowflakeKey {
     TRADE_ID,
-
-    PAYMENT_ID
+    PAYMENT_ID,
+    MALL_BIZ_ORDER_ID,
+    MALL_BIZ_PAYMENT_ID,
+    MALL_BIZ_REFUND_ID,
+    ;
 }