创建订单接口定义

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/controller/app/order/AppTradeOrderController.java

@@ -1,15 +1,19 @@
 package cn.iocoder.yudao.module.trade.controller.app.order;
 
+import cn.hutool.extra.servlet.ServletUtil;
 import cn.iocoder.yudao.framework.common.pojo.CommonResult;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.framework.security.core.annotations.PreAuthenticated;
+import cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils;
 import cn.iocoder.yudao.module.trade.controller.app.order.vo.AppTradeOrderCreateReqVO;
 import cn.iocoder.yudao.module.trade.controller.app.order.vo.AppTradeOrderGetCreateInfoRespVO;
 import cn.iocoder.yudao.module.trade.controller.app.order.vo.TradeOrderPageReqVO;
 import cn.iocoder.yudao.module.trade.controller.app.order.vo.TradeOrderRespVO;
+import cn.iocoder.yudao.module.trade.service.order.TradeOrderService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
@@ -19,12 +23,16 @@ import javax.servlet.http.HttpServletRequest;
 @Api(tags = "用户 App - 交易订单")
 @RestController
 @RequestMapping("/trade/order")
+@RequiredArgsConstructor
 @Validated
 @Slf4j
 public class AppTradeOrderController {
 
     // TODO 在思考下；
 
+    private final TradeOrderService tradeOrderService;
+
+
     @GetMapping("/get-create-info")
     @ApiOperation("基于商品，确认创建订单")
     @PreAuthenticated
@@ -36,11 +44,18 @@ public class AppTradeOrderController {
     @PostMapping("/create")
     @ApiOperation("创建订单")
     @PreAuthenticated
-    public CommonResult<Integer> createTradeOrder(@RequestBody AppTradeOrderCreateReqVO createReqVO,
-                                                  HttpServletRequest servletRequest) {
+    public CommonResult<Long> createTradeOrder(@RequestBody AppTradeOrderCreateReqVO createReqVO,
+                                               HttpServletRequest servletRequest) {
 //        return success(tradeOrderService.createTradeOrder(UserSecurityContextHolder.getUserId(),
 //                HttpUtil.getIp(servletRequest), createReqVO));
-        return null;
+        // 获取登录用户
+        Long loginUserId = SecurityFrameworkUtils.getLoginUserId();
+        // 获取用户ip地址
+        String clientIp = ServletUtil.getClientIP(servletRequest);
+        // 创建交易订单，预支付记录
+        Long result = tradeOrderService.createTradeOrder(loginUserId, clientIp, createReqVO);
+
+        return CommonResult.success(result);
     }
 
     @GetMapping("/get")

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/controller/app/order/vo/AppTradeOrderCreateReqVO.java

@@ -38,7 +38,7 @@ public class AppTradeOrderCreateReqVO {
 
         @ApiModelProperty(name = "商品 SKU 编号", required = true, example = "111")
         @NotNull(message = "商品 SKU 编号不能为空")
-        private Integer skuId;
+        private Long skuId;
 
         @ApiModelProperty(name = "商品 SKU 购买数量", required = true, example = "1024")
         @NotNull(message = "商品 SKU 购买数量不能为空")

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/convert/order/TradeOrderConvert.java

@@ -0,0 +1,20 @@
+package cn.iocoder.yudao.module.trade.convert.order;
+
+import cn.iocoder.yudao.module.market.api.price.dto.PriceCalculateRespDTO;
+import cn.iocoder.yudao.module.trade.controller.app.order.vo.AppTradeOrderCreateReqVO;
+import cn.iocoder.yudao.module.trade.dal.dataobject.order.TradeOrderDO;
+import org.mapstruct.Mapper;
+import org.mapstruct.factory.Mappers;
+
+/**
+ * @author LeeYan9
+ * @since 2022-08-26
+ */
+@Mapper
+public interface TradeOrderConvert {
+
+    TradeOrderConvert INSTANCE = Mappers.getMapper(TradeOrderConvert.class);
+
+
+    TradeOrderDO convert(AppTradeOrderCreateReqVO createReqVO, PriceCalculateRespDTO.Order order);
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/convert/order/TradeOrderItemConvert.java

@@ -0,0 +1,33 @@
+package cn.iocoder.yudao.module.trade.convert.order;
+
+import cn.iocoder.yudao.module.market.api.price.dto.PriceCalculateRespDTO;
+import cn.iocoder.yudao.module.trade.dal.dataobject.order.TradeOrderDO;
+import cn.iocoder.yudao.module.trade.dal.dataobject.order.TradeOrderItemDO;
+import org.mapstruct.Mapper;
+import org.mapstruct.Mapping;
+import org.mapstruct.Mappings;
+import org.mapstruct.factory.Mappers;
+
+import java.util.List;
+
+/**
+ * @author LeeYan9
+ * @since 2022-08-26
+ */
+@Mapper
+public interface TradeOrderItemConvert {
+
+    TradeOrderItemConvert INSTANCE = Mappers.getMapper(TradeOrderItemConvert.class);
+
+    /**
+     *
+     * @param tradeOrder 交易订单
+     * @param items sku列表价格
+     * @return 订单项
+     */
+    @Mappings({
+            @Mapping(source = "tradeOrder.userId", target = "userId"),
+            @Mapping(source = "tradeOrder.orderId", target = "orderId")
+    })
+    List<TradeOrderItemDO> convertList(TradeOrderDO tradeOrder, List<PriceCalculateRespDTO.Item> items);
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/convert/pay/PayOrderConvert.java

@@ -0,0 +1,17 @@
+package cn.iocoder.yudao.module.trade.convert.pay;
+
+import cn.iocoder.yudao.module.pay.api.order.PayOrderDataCreateReqDTO;
+import cn.iocoder.yudao.module.trade.dal.dataobject.order.TradeOrderDO;
+import org.mapstruct.factory.Mappers;
+
+/**
+ * @author LeeYan9
+ * @since 2022-08-26
+ */
+public interface PayOrderConvert {
+
+    PayOrderConvert INSTANCE = Mappers.getMapper(PayOrderConvert.class);
+
+
+    PayOrderDataCreateReqDTO convert(TradeOrderDO tradeOrderDO);
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/convert/price/PriceConvert.java

@@ -0,0 +1,23 @@
+package cn.iocoder.yudao.module.trade.convert.price;
+
+import cn.iocoder.yudao.module.market.api.price.dto.PriceCalculateReqDTO;
+import cn.iocoder.yudao.module.trade.controller.app.order.vo.AppTradeOrderCreateReqVO;
+import org.mapstruct.Mapper;
+import org.mapstruct.Mapping;
+import org.mapstruct.Mappings;
+import org.mapstruct.factory.Mappers;
+
+/**
+ * @author LeeYan9
+ * @since 2022-08-26
+ */
+@Mapper
+public interface PriceConvert {
+
+    PriceConvert INSTANCE = Mappers.getMapper(PriceConvert.class);
+
+    @Mappings(
+            @Mapping(source = "userId" , target = "userId")
+    )
+    PriceCalculateReqDTO convert(AppTradeOrderCreateReqVO createReqVO , Long userId);
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/convert/sku/ProductSkuConvert.java

@@ -0,0 +1,20 @@
+package cn.iocoder.yudao.module.trade.convert.sku;
+
+import cn.iocoder.yudao.module.product.api.sku.dto.SkuDecrementStockBatchReqDTO;
+import cn.iocoder.yudao.module.trade.dal.dataobject.order.TradeOrderItemDO;
+import org.mapstruct.Mapper;
+import org.mapstruct.factory.Mappers;
+
+import java.util.List;
+
+/**
+ * @author LeeYan9
+ * @since 2022-08-26
+ */
+@Mapper
+public interface ProductSkuConvert {
+
+    ProductSkuConvert INSTANCE = Mappers.getMapper(ProductSkuConvert.class);
+
+    List<SkuDecrementStockBatchReqDTO.Item> convert(List<TradeOrderItemDO> tradeOrderItems);
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/dal/mysql/order/TradeOrderMapper.java

@@ -0,0 +1,11 @@
+package cn.iocoder.yudao.module.trade.dal.mysql.order;
+
+import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
+import cn.iocoder.yudao.module.trade.dal.dataobject.order.TradeOrderDO;
+
+/**
+ * @author LeeYan9
+ * @since 2022-08-26
+ */
+public interface TradeOrderMapper extends BaseMapperX<TradeOrderDO> {
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/dal/mysql/orderitem/TradeOrderItemMapper.java

@@ -0,0 +1,11 @@
+package cn.iocoder.yudao.module.trade.dal.mysql.orderitem;
+
+import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
+import cn.iocoder.yudao.module.trade.dal.dataobject.order.TradeOrderItemDO;
+
+/**
+ * @author LeeYan9
+ * @since 2022-08-26
+ */
+public interface TradeOrderItemMapper extends BaseMapperX<TradeOrderItemDO> {
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/service/order/TradeOrderService.java

@@ -0,0 +1,19 @@
+package cn.iocoder.yudao.module.trade.service.order;
+
+import cn.iocoder.yudao.module.trade.controller.app.order.vo.AppTradeOrderCreateReqVO;
+
+/**
+ * @author LeeYan9
+ * @since 2022-08-26
+ */
+public interface TradeOrderService {
+
+    /**
+     * 创建交易订单
+     * @param loginUserId 登录用户
+     * @param clientIp 用户ip地址
+     * @param createReqVO 创建交易订单请求模型
+     * @return 交易订单创建结果
+     */
+    Long createTradeOrder(Long loginUserId, String clientIp, AppTradeOrderCreateReqVO createReqVO);
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/service/order/TradeOrderServiceImpl.java

@@ -0,0 +1,138 @@
+package cn.iocoder.yudao.module.trade.service.order;
+
+import cn.hutool.core.bean.BeanUtil;
+import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
+import cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil;
+import cn.iocoder.yudao.framework.common.util.collection.CollectionUtils;
+import cn.iocoder.yudao.module.market.api.price.PriceApi;
+import cn.iocoder.yudao.module.market.api.price.dto.PriceCalculateReqDTO;
+import cn.iocoder.yudao.module.market.api.price.dto.PriceCalculateRespDTO;
+import cn.iocoder.yudao.module.pay.api.order.PayOrderApi;
+import cn.iocoder.yudao.module.pay.api.order.PayOrderDataCreateReqDTO;
+import cn.iocoder.yudao.module.product.api.sku.ProductSkuApi;
+import cn.iocoder.yudao.module.product.api.sku.dto.SkuDecrementStockBatchReqDTO;
+import cn.iocoder.yudao.module.product.api.sku.dto.SkuInfoRespDTO;
+import cn.iocoder.yudao.module.product.api.spu.ProductSpuApi;
+import cn.iocoder.yudao.module.product.api.spu.dto.SpuInfoRespDTO;
+import cn.iocoder.yudao.module.product.enums.spu.ProductSpuStatusEnum;
+import cn.iocoder.yudao.module.trade.controller.app.order.vo.AppTradeOrderCreateReqVO;
+import cn.iocoder.yudao.module.trade.controller.app.order.vo.AppTradeOrderCreateReqVO.Item;
+import cn.iocoder.yudao.module.trade.convert.order.TradeOrderConvert;
+import cn.iocoder.yudao.module.trade.convert.order.TradeOrderItemConvert;
+import cn.iocoder.yudao.module.trade.convert.pay.PayOrderConvert;
+import cn.iocoder.yudao.module.trade.convert.price.PriceConvert;
+import cn.iocoder.yudao.module.trade.convert.sku.ProductSkuConvert;
+import cn.iocoder.yudao.module.trade.dal.dataobject.order.TradeOrderDO;
+import cn.iocoder.yudao.module.trade.dal.dataobject.order.TradeOrderItemDO;
+import cn.iocoder.yudao.module.trade.dal.mysql.order.TradeOrderMapper;
+import cn.iocoder.yudao.module.trade.dal.mysql.orderitem.TradeOrderItemMapper;
+import cn.iocoder.yudao.module.trade.enums.enums.ErrorCodeConstants;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+
+/**
+ * @author LeeYan9
+ * @since 2022-08-26
+ */
+@Service
+@RequiredArgsConstructor
+public class TradeOrderServiceImpl implements TradeOrderService {
+
+    private final TradeOrderMapper tradeOrderMapper;
+
+    private final TradeOrderItemMapper tradeOrderItemMapper;
+
+    private final PriceApi priceApi;
+
+    private final ProductSkuApi productSkuApi;
+
+    private final ProductSpuApi productSpuApi;
+
+    private final PayOrderApi payOrderApi;
+
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public Long createTradeOrder(Long loginUserId, String clientIp, AppTradeOrderCreateReqVO createReqVO) {
+
+        List<Item> items = createReqVO.getItems();
+        //  商品SKU检查 sku可售状态,库存
+        List<SkuInfoRespDTO> skuInfos = productSkuApi.getSkusByIds(CollectionUtils.convertSet(items, Item::getSkuId));
+        Map<Long, SkuInfoRespDTO> skuInfoMap = CollectionUtils.convertMap(skuInfos, SkuInfoRespDTO::getId);
+        checkSaleableAndStockFromSpu(skuInfoMap, items);
+
+        //  商品SPU检查 sku可售状态,库存
+        List<SpuInfoRespDTO> spuInfos = productSpuApi.getSpusByIds(CollectionUtils.convertSet(skuInfos, SkuInfoRespDTO::getSpuId));
+        checkSaleableFromSpu(spuInfos);
+
+        // 价格计算
+        PriceCalculateReqDTO priceCalculateReqDTO = PriceConvert.INSTANCE.convert(createReqVO, loginUserId);
+        PriceCalculateRespDTO priceResp = priceApi.calculatePrice(priceCalculateReqDTO);
+
+        // 订单信息记录
+        TradeOrderDO tradeOrderDO = TradeOrderConvert.INSTANCE.convert(createReqVO, priceResp.getOrder());
+        tradeOrderMapper.insert(tradeOrderDO);
+
+        // 订单项信息记录
+        List<TradeOrderItemDO> tradeOrderItems = TradeOrderItemConvert.INSTANCE.convertList(tradeOrderDO, priceResp.getItems());
+        //-填充订单项-SKU信息
+        fillItemsInfoFromSku(tradeOrderItems, skuInfoMap);
+        tradeOrderItemMapper.insertBatch(tradeOrderItems);
+
+        // 库存扣减
+        List<SkuDecrementStockBatchReqDTO.Item> skuDecrementStockItems = ProductSkuConvert.INSTANCE.convert(tradeOrderItems);
+        productSkuApi.decrementStockBatch(SkuDecrementStockBatchReqDTO.of(skuDecrementStockItems));
+        // 生成预支付
+
+        PayOrderDataCreateReqDTO payOrderCreateReqDTO = PayOrderConvert.INSTANCE.convert(tradeOrderDO);
+        return payOrderApi.createPayOrder(payOrderCreateReqDTO);
+    }
+
+    private void fillItemsInfoFromSku(List<TradeOrderItemDO> tradeOrderItems,
+                                      Map<Long, SkuInfoRespDTO> spuInfos) {
+        for (TradeOrderItemDO tradeOrderItem : tradeOrderItems) {
+            // 填充SKU信息
+            SkuInfoRespDTO skuInfoRespDTO = spuInfos.get(tradeOrderItem.getSkuId());
+            tradeOrderItem.setSpuId(skuInfoRespDTO.getSpuId());
+            tradeOrderItem.setPicUrl(skuInfoRespDTO.getPicUrl());
+            tradeOrderItem.setName(skuInfoRespDTO.getName());
+            // todo
+            List<TradeOrderItemDO.Property> property =
+                    BeanUtil.copyToList(skuInfoRespDTO.getProperties(), TradeOrderItemDO.Property.class);
+            tradeOrderItem.setProperties(property);
+        }
+    }
+
+    private void checkSaleableFromSpu(List<SpuInfoRespDTO> spuInfos) {
+        SpuInfoRespDTO spu = CollectionUtils.findFirst(spuInfos,
+                spuInfoDTO -> !Objects.equals(ProductSpuStatusEnum.ENABLE.getStyle(), spuInfoDTO.getStatus()));
+        if (Objects.isNull(spu)) {
+            throw ServiceExceptionUtil.exception(ErrorCodeConstants.ORDER_SPU_NOT_SALE);
+        }
+    }
+
+    private void checkSaleableAndStockFromSpu(Map<Long, SkuInfoRespDTO> skuInfoMap,
+                                              List<Item> items) {
+        // sku 不存在
+        if (items.size() != skuInfoMap.size()) {
+            throw ServiceExceptionUtil.exception(ErrorCodeConstants.ORDER_SKU_NOT_FOUND);
+        }
+        for (Item item : items) {
+            SkuInfoRespDTO skuInfoDTO = skuInfoMap.get(item.getSkuId());
+            // sku禁用
+            if (!Objects.equals(CommonStatusEnum.ENABLE.getStatus(), skuInfoDTO.getStatus())) {
+                throw ServiceExceptionUtil.exception(ErrorCodeConstants.ORDER_SKU_NOT_SALE);
+            }
+            // sku库存不足
+            if (item.getCount() > skuInfoDTO.getStock()) {
+                throw ServiceExceptionUtil.exception(ErrorCodeConstants.ORDER_SKU_STOCK_NOT_ENOUGH);
+            }
+        }
+
+    }
+}