【第十八篇】商城系統-訂單中心設計解決方案

訂單子產品

一、資源整合

我們需要把相關的靜态資源拷貝到nginx，然後動态模闆檔案拷貝到order項目的templates目錄下，然後調整資源的路徑。在網關中設定對應的路由即可。

二、整合SpringSession

結合官網，導入對應的依賴，然後添加對應的配置資訊，redis配置資訊，Cookie的配置一級域名和二級域名。

三、訂單中心

訂單中心涉及到的子產品

訂單的狀态：

待付款:送出訂單，訂單預下單
已付款/待發貨：完成支付，訂單系統需要記錄支付時間，支付流水号便于對賬，訂單下放到wms系統，倉庫進行調撥，配貨，分揀，出庫等操作
待收款/已發貨:倉庫将商品出庫，訂單進入物流環節
已完成:使用者确認收貨，訂單交易完成，後續支付側進行結算，如果訂單存在問題就進入售後狀态
已取消:付款之前取消訂單。
售後中：使用者在付款後申請退款，或商家發貨後使用者申請退換貨。

訂單流程：

四、認證攔截

訂單服務中的所有的請求都必須是在認證的狀态下處理的，所有我們需要添加一個校驗是否認證的攔截器

package com.msb.mall.order.interceptor;

import com.msb.common.constant.AuthConstant;
import com.msb.common.vo.MemberVO;
import org.springframework.web.servlet.HandlerInterceptor;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

public class AuthInterceptor implements HandlerInterceptor {

    public static ThreadLocal threadLocal = new ThreadLocal();

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        // 通過HttpSession擷取目前登入的使用者資訊
        HttpSession session = request.getSession();
        Object attribute = session.getAttribute(AuthConstant.AUTH_SESSION_REDIS);
        if(attribute != null){
            MemberVO memberVO = (MemberVO) attribute;
            threadLocal.set(memberVO);
            return true;
        }
        // 如果 attribute == null 說明沒有登入，那麼我們就需要重定向到登入頁面
        session.setAttribute(AuthConstant.AUTH_SESSION_MSG,"請先登入");
        response.sendRedirect("http://auth.msb.com/login.html");
        return false;
    }
}

然後注冊該攔截器即可

@Configuration
public class MyWebInterceptorConfig implements WebMvcConfigurer {
    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(new AuthInterceptor()).addPathPatterns("/**");
    }

}

五、訂單确認頁

1.訂單确認頁VO抽取

public class OrderConfirmVo {

    // 訂單的收貨人 及 收貨位址資訊
    @Getter @Setter
    List<MemberAddressVo> address;
    // 購物車中選中的商品資訊
    @Getter @Setter
    List<OrderItemVo> items;
    // 支付方式
    // 發票資訊
    // 優惠資訊

    //Integer countNum;

    public Integer getCountNum(){
        int count = 0;
        if(items != null){
            for (OrderItemVo item : items) {
                count += item.getCount();
            }
        }
        return count;
    }

    // BigDecimal total ;// 總的金額
    public BigDecimal getTotal(){
        BigDecimal sum = new BigDecimal(0);
        if(items != null ){
            for (OrderItemVo item : items) {
                BigDecimal totalPrice = item.getPrice().multiply(new BigDecimal(item.getCount()));
                sum = sum.add(totalPrice);
            }
        }
        return sum;
    }
    // BigDecimal payTotal;// 需要支付的總金額
    public BigDecimal getPayTotal(){
        return getTotal();
    }
}

2.确認頁資料擷取

通過Fegin遠端調用對應的服務，擷取會員的資料和購物車中的商品資訊。

@Override
    public OrderConfirmVo confirmOrder() {
        OrderConfirmVo vo = new OrderConfirmVo();
        MemberVO memberVO = (MemberVO) AuthInterceptor.threadLocal.get();
        // 擷取到 RequestContextHolder 的相關資訊
        RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
        CompletableFuture<Void> future1 = CompletableFuture.runAsync(() -> {
            // 同步主線程中的 RequestContextHolder
            RequestContextHolder.setRequestAttributes(requestAttributes);
            // 1.查詢目前登入使用者對應的會員的位址資訊
            Long id = memberVO.getId();
            List<MemberAddressVo> addresses = memberFeginService.getAddress(id);
            vo.setAddress(addresses);
        }, executor);
        CompletableFuture<Void> future2 = CompletableFuture.runAsync(() -> {
            RequestContextHolder.setRequestAttributes(requestAttributes);
            // 2.查詢購物車中選中的商品資訊
            List<OrderItemVo> userCartItems = cartFeginService.getUserCartItems();
            vo.setItems(userCartItems);
        }, executor);
        try {
            CompletableFuture.allOf(future1,future2).get();
        } catch (Exception e) {
            e.printStackTrace();
        }
        // 3.計算訂單的總金額和需要支付的總金額 VO自動計算
        return vo;
    }

在Fegin調用遠端服務的時候會出現請求Header丢失的問題。

首先我們建立

RequestInterceptor

的實作來綁定Header資訊，同時在異步處理的時候我們需要從主線程中擷取Request資訊，然後綁定在子線程中。

然後在訂單确認頁中渲染資料的展示

最後的頁面效果

六、接口幂等性處理

幂等性：多次調用方法或者接口不會改變業務狀态，可以保證重複調用的結果和單次調用的結果一緻。

1.天然的幂等行為

以SQL語句為例：

select * from t_user where id = 1;
update t_user set age = 18 where id = 2;
delete from t_user where id = 1
insert into (userid,username)values(1,'波哥') ; # userid 唯一主鍵

不具備幂等行為的

update t_user set age = age + 1 where id = 1;
insert into (userid,username)values(1,'波哥'); # userid 不是主鍵 可以重複

2.需要使用幂等的場景

需要使用幂等的場景：

前端重複送出
接口逾時重試
消息隊列重複消費

3.解決方案

token機制：①用戶端請求擷取token，服務端生成一個唯一ID作為token存在redis中；②用戶端第二次請求時攜帶token，服務端校驗token成功則執行業務操作并删除token，服務端校驗token失敗則表示重複操作。
基于mysql：①建立去重表；②服務端将用戶端請求時送出的部分資訊放入表中，其中有唯一索引字段；③成功插入則沒有重複請求，插入失敗則重複請求。
基于redis：①用戶端請求服務端拿本次請求的辨別字段；②服務端将辨別字段以setnx方式存入redis并設定過期時間；③設定成功則說明非重複操作，設定失敗則表示重複操作。
狀态機、悲觀鎖、樂觀鎖等。

七、送出訂單

1.防重送出

在訂單送出的時候我們通過防重Token來保證請求的幂等性

2.生成Token

我們在擷取訂單結算頁資料的service中我們需要生成對應的Token，并且儲存到Redis中同時綁定到頁面。

頁面中的處理

3.送出訂單

然後在送出訂單的邏輯中我們先建立對應的VO

@Data
public class OrderSubmitVO {

    // 收獲位址的id
    private Long addrId;

    // 支付方式
    private Integer payType;

    // 防重Token
    private String orderToken;

    // 買家備注
    private String note;
}

然後在訂單确認頁中建立對應的form表單

然後把資料送出到後端服務中。

4.防重檢查

訂單資料送出到後端服務，我們在下訂單前需要做防重送出的校驗。

try{
            lock.lock();//加鎖
            String redisToken = redisTemplate.opsForValue().get(key);
            if(redisToken != null && redisToken.equals(vo.getOrderToken())){
                // 表示是第一次送出
                // 需要删除Token
                redisTemplate.delete(key);
            }else{
                // 表示是重複送出
                return responseVO;
            }
        }finally {
            lock.unlock(); //釋放鎖
        }

上面我們是通過Lock加鎖的方式來實作Redis中的查詢和删除操作的原子性，我們同時可以使用Redis中腳本來實作原子性處理。

// 擷取目前登入的使用者資訊
        MemberVO memberVO = (MemberVO) AuthInterceptor.threadLocal.get();
        // 1.驗證是否重複送出  保證Redis中的token 的查詢和删除是一個原子性操作
        String key = OrderConstant.ORDER_TOKEN_PREFIX+":"+memberVO.getId();
        String script = "if redis.call('get',KEYS[1])==ARGV[1] then return redis.call('del',KEYS[1]) else return 0";
        Long result = redisTemplate.execute(new DefaultRedisScript<Long>(script, Long.class)
                , Arrays.asList(key)
                , vo.getOrderToken());
        if(result == 0){
            // 表示驗證失敗 說明是重複送出
            return responseVO;
        }

八、生成訂單

一個是需要生成訂單資訊一個是需要生成訂單項資訊。具體的核心代碼為

/**
     * 建立訂單的方法
     * @param vo
     * @return
     */
    private OrderCreateTO createOrder(OrderSubmitVO vo) {
        OrderCreateTO createTO = new OrderCreateTO();
        // 建立訂單
        OrderEntity orderEntity = buildOrder(vo);
        createTO.setOrderEntity(orderEntity);
        // 建立OrderItemEntity 訂單項
        List<OrderItemEntity> orderItemEntitys = buildOrderItems(orderEntity.getOrderSn());
        createTO.setOrderItemEntitys(orderItemEntitys);
        return createTO;
    }

    /**
     * 通過購物車中選中的商品來建立對應的購物項資訊
     * @return
     */
    private List<OrderItemEntity> buildOrderItems(String orderSN) {
        List<OrderItemEntity> orderItemEntitys = new ArrayList<>();
        // 擷取購物車中的商品資訊 選中的
        List<OrderItemVo> userCartItems = cartFeginService.getUserCartItems();
        if(userCartItems != null && userCartItems.size() > 0){
            // 統一根據SKUID查詢出對應的SPU的資訊
            List<Long> spuIds = new ArrayList<>();
            for (OrderItemEntity orderItemEntity : orderItemEntitys) {
                if(!spuIds.contains(orderItemEntity.getSpuId())){
                    spuIds.add(orderItemEntity.getOrderId());
                }
            }
            // 遠端調用商品服務擷取到對應的SPU資訊
            List<OrderItemSpuInfoVO> spuInfos = productService.getOrderItemSpuInfoBySpuId((Long[]) spuIds.toArray());
            Map<Long, OrderItemSpuInfoVO> map = spuInfos.stream().collect(Collectors.toMap(OrderItemSpuInfoVO::getId, item -> item));
            for (OrderItemVo userCartItem : userCartItems) {
                // 擷取到商品資訊對應的 SPU資訊
                OrderItemSpuInfoVO spuInfo  = map.get(userCartItem.getSpuId());
                OrderItemEntity orderItemEntity = buildOrderItem(userCartItem,spuInfo);
                // 綁定對應的訂單編号
                orderItemEntity.setOrderSn(orderSN);
                orderItemEntitys.add(orderItemEntity);
            }
        }

        return orderItemEntitys;
    }

    /**
     * 根據一個購物車中的商品建立對應的 訂單項
     * @param userCartItem
     * @return
     */
    private OrderItemEntity buildOrderItem(OrderItemVo userCartItem,OrderItemSpuInfoVO spuInfo) {
        OrderItemEntity entity = new OrderItemEntity();
        // SKU資訊
        entity.setSkuId(userCartItem.getSkuId());
        entity.setSkuName(userCartItem.getTitle());
        entity.setSkuPic(userCartItem.getImage());
        entity.setSkuQuantity(userCartItem.getCount());
        List<String> skuAttr = userCartItem.getSkuAttr();
        String skuAttrStr = StringUtils.collectionToDelimitedString(skuAttr, ";");
        entity.setSkuAttrsVals(skuAttrStr);
        // SPU資訊
        entity.setSpuId(spuInfo.getId());
        entity.setSpuBrand(spuInfo.getBrandName());
        entity.setCategoryId(spuInfo.getCatalogId());
        entity.setSpuPic(spuInfo.getImg());
        // 優惠資訊 忽略
        // 積分資訊
        entity.setGiftGrowth(userCartItem.getPrice().intValue());
        entity.setGiftIntegration(userCartItem.getPrice().intValue());
        return entity;
    }

    private OrderEntity buildOrder(OrderSubmitVO vo) {
        // 建立OrderEntity
        OrderEntity orderEntity = new OrderEntity();
        // 建立訂單編号
        String orderSn = IdWorker.getTimeId();
        orderEntity.setOrderSn(orderSn);
        MemberVO memberVO = (MemberVO) AuthInterceptor.threadLocal.get();
        // 設定會員相關的資訊
        orderEntity.setMemberId(memberVO.getId());
        orderEntity.setMemberUsername(memberVO.getUsername());
        // 根據收獲位址ID擷取收獲位址的詳細資訊
        MemberAddressVo memberAddressVo = memberFeginService.getAddressById(vo.getAddrId());
        orderEntity.setReceiverCity(memberAddressVo.getCity());
        orderEntity.setReceiverDetailAddress(memberAddressVo.getDetailAddress());
        orderEntity.setReceiverName(memberAddressVo.getName());
        orderEntity.setReceiverPhone(memberAddressVo.getPhone());
        orderEntity.setReceiverPostCode(memberAddressVo.getPostCode());
        orderEntity.setReceiverRegion(memberAddressVo.getRegion());
        orderEntity.setReceiverProvince(memberAddressVo.getProvince());
        // 設定訂單的狀态
        orderEntity.setStatus(OrderConstant.OrderStateEnum.FOR_THE_PAYMENT.getCode());
        return orderEntity;
    }

鎖定庫存的操作，需要操作ware倉儲服務。

/**
     * 鎖定庫存的操作
     * @param vo
     * @return
     */
    @Transactional
    @Override
    public Boolean orderLockStock(WareSkuLockVO vo) {
        List<OrderItemVo> items = vo.getItems();
        // 首先找到具有庫存的倉庫
        List<SkuWareHasStock> collect = items.stream().map(item -> {
            SkuWareHasStock skuWareHasStock = new SkuWareHasStock();
            skuWareHasStock.setSkuId(item.getSkuId());
            List<WareSkuEntity> wareSkuEntities = this.baseMapper.listHashStock(item.getSkuId());
            skuWareHasStock.setWareSkuEntities(wareSkuEntities);
            skuWareHasStock.setNum(item.getCount());
            return skuWareHasStock;
        }).collect(Collectors.toList());
        // 嘗試鎖定庫存
        for (SkuWareHasStock skuWareHasStock : collect) {
            Long skuId = skuWareHasStock.getSkuId();
            List<WareSkuEntity> wareSkuEntities = skuWareHasStock.wareSkuEntities;
            if(wareSkuEntities == null && wareSkuEntities.size() == 0){
                // 目前商品沒有庫存了
                throw new NoStockExecption(skuId);
            }
            // 目前需要鎖定的商品的梳理
            Integer count = skuWareHasStock.getNum();
            Boolean skuStocked = false; // 表示目前SkuId的庫存沒有鎖定完成
            for (WareSkuEntity wareSkuEntity : wareSkuEntities) {
                // 循環擷取到對應的 倉庫，然後需要鎖定庫存
                // 擷取目前倉庫能夠鎖定的庫存數
                Integer canStock = wareSkuEntity.getStock() - wareSkuEntity.getStockLocked();
                if(count <= canStock){
                    // 表示目前的skuId的商品的數量小于等于需要鎖定的數量
                    Integer i = this.baseMapper.lockSkuStock(skuId,wareSkuEntity.getWareId(),count);
                    count = 0;
                    skuStocked = true;
                }else{
                    // 需要鎖定的庫存大于 可以鎖定的庫存 就按照已有的庫存來鎖定
                    Integer i = this.baseMapper.lockSkuStock(skuId,wareSkuEntity.getWareId(),canStock);
                    count = count - canStock;
                }
                if(count <= 0 ){
                    // 表示所有的商品都鎖定了
                    break;
                }
            }
            if(count > 0){
                // 說明庫存沒有鎖定完
                throw new NoStockExecption(skuId);
            }
            if(skuStocked == false){
                // 表示上一個商品的沒有鎖定庫存成功
                throw new NoStockExecption(skuId);
            }
        }
        return true;
    }

沒有庫存或者鎖定庫存失敗我們通過自定義的異常抛出

/**
 * 自定義異常：鎖定庫存失敗的情況下産生的異常信
 */
public class NoStockExecption extends RuntimeException{

    private Long skuId;

    public NoStockExecption(Long skuId){
        super("目前商品["+skuId+"]沒有庫存了");
        this.skuId = skuId;

    }

    public Long getSkuId() {
        return skuId;
    }

    public void setSkuId(Long skuId) {
        this.skuId = skuId;
    }
}

如果下訂單操作成功（訂單資料和訂單項資料）我們就會操作鎖庫存的行為

【第十八篇】商城系統-訂單中心設計解決方案

訂單子產品

一、資源整合

二、整合SpringSession

三、訂單中心

四、認證攔截

五、訂單确認頁

1.訂單确認頁VO抽取

2.确認頁資料擷取

六、接口幂等性處理

1.天然的幂等行為

2.需要使用幂等的場景

3.解決方案

七、送出訂單

1.防重送出

2.生成Token

3.送出訂單

4.防重檢查

八、生成訂單

繼續閱讀

關于Gradle配置的小結

Java小案例——随機數猜測随機數猜測

nginx location中斜線的位置的重要性

27 Best Free Eclipse Plug-ins for Java Developer to be ProductiveCode Quality PluginsText Editor PluginsDependency ManagementVersion Control Integration PluginsFramework Development Continuous Integration Related PluginsOther Utility Plugins

Java String.format方法的簡單使用

neo4j之cypher使用文檔

GitHub連夜封殺！這份阿裡 10W 字内部 Java 字面試手冊到底有多強？

spark/scala關于【資源檔案】加載方法概述外部檔案加載方案測試資源檔案打包入jar包中小結

mybatis_入門程式Mybatis入門

AOP程式設計_Android優雅權限架構(1)概念基礎，2021金三銀四前言正文大綱正文

Effective Java 8:通用程式設計

OOM三種類型

工廠模式-三種類型

【遞歸】高效率求2的n次幂

win10本地scala和spark安裝安裝scala安裝spark

scala (3) Function 和 Method