# Apache-Camel-For-Order

**Repository Path**: xiaowan_/Apache-Camel-For-Order

## Basic Information

- **Project Name**: Apache-Camel-For-Order
- **Description**: rebuild order center with Apache Camel
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 1
- **Forks**: 2
- **Created**: 2021-03-17
- **Last Updated**: 2022-04-01

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

rebuild order-center using apache camel
```java
public void configure() throws Exception {

    /**聚合下单入参,目前该流程未开启事务，如需开启，需spring配置事务管理器*/
    from("direct:aggregationInputOrderParam")
        // .transacted()
        .choice()
            .when(bodyAs(PreCartOrder.class))
            .when(bodyAs(SubmitCartOrder.class))
                .bean(orderInputParamConvertComponent, "generateSubmitCartItemInfo")
            .otherwise()
                .bean(orderInputParamConvertComponent, "generateSubmitItemInfo")
        .end()
        /**调用商品中心，组装商品详情*/
        .bean(productComponent)
        /**调用商家中心，获取店铺详情*/
        .bean(shopComponent)
        .enrich("direct:checkAvailability")
        //.bean("按照商家维度聚合itemDetail")
        /**营销流程*/
        .enrich("direct:useDiscount")
        //.bean("获取运费，均摊运费")
        //.bean("拆单")
        /**如果是预订单，直接返回，如果是提交订单，执行后续流程*/
        .choice()
            .when(header("operationType").isEqualTo(PreOrder.class.getSimpleName()))
                .bean(preOrderResultComponent)
            .otherwise().enrich("direct:saveOrder")
        .end();

    /**下单校验，包含itemDetail有效性，收货地址有效性等*/
    from("direct:checkAvailability")
        // .bean("收货地址是否有效")
        .choice()
            .when(new Predicate() {
                @Override
                public boolean matches(Exchange exchange) {
                    /**判断是否需要检查库存*/
                    return false;
                }
            }).bean(productComponent)
        .end()
        .bean(productComponent, "checkInvalidItemDetail");

    /**营销组件*/
    from("direct:useDiscount")
        .routingSlip().method(UseDiscount.class, "useDiscountMethod");

    /**提交订单后续流程*/
    from("direct:saveOrder")
        .bean(saveOrderComponent)
        .bean(preLockFundComponent)
        .choice()
            .when(new Predicate() {
                @Override
                public boolean matches(Exchange exchange) {
                    /**判断是否需要扣库存*/
                    return false;
                }
            }).bean(preLockStockComponent)
        .end()
        .bean(afterSubmitOrderComponent)
        .bean(submitOrderResultComponent);
}
```