/**
 * 登入攔截器
 * 從session中獲取了登入信息（redis中），封裝到了ThreadLocal中
 */
@Component
public class LoginUserInterceptor implements HandlerInterceptor {

    public static ThreadLocal<MemberResponseTo> loginUser = new ThreadLocal<>();

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {

        // 獲取登入的用戶信息
        MemberResponseTo attribute = (MemberResponseTo) request.getSession().getAttribute(LOGIN_USER);

        if (attribute != null) {
            // 把登入後用戶的信息放在ThreadLocal裡面進行保存
            loginUser.set(attribute);

            return true;
        } else {
            // 未登入，返回登入頁面
            response.setContentType("text/html;charset=UTF-8");
            PrintWriter out = response.getWriter();
            out.println("<script>alert('請先進行登入，再進行後續操作！');location.href='http://auth.mall.com/login.html'</script>");
            // session.setAttribute("msg", "請先進行登入");
            // response.sendRedirect("http://auth.mall.com/login.html");
            return false;
        }
    }
}

/**
 * 訂單確認頁需要用的數據
 */
public class OrderConfirmVo {

    /**
     * 會員收貨地址列表
     **/
    @Getter
    @Setter
    List<MemberAddressTo> memberAddressTos;

    /**
     * 所有選中的購物項【購物車中的所有項】
     **/
    @Getter
    @Setter
    List<OrderItemTo> items;

    /**
     * 優惠券（會員積分）
     **/
    @Getter
    @Setter
    private Integer integration;

    /**
     * 防止重複提交的令牌 冪等性
     **/
    @Getter
    @Setter
    private String orderToken;

    @Getter
    @Setter
    Map<Long, Boolean> stocks;

    public Integer getCount() {
        Integer count = 0;
        if (items != null && items.size() > 0) {
            for (OrderItemTo item : items) {
                count += item.getCount();
            }
        }
        return count;
    }

    /**
     * 總商品金額
     **/
    //BigDecimal total;
    //計算訂單總額
    public BigDecimal getTotal() {
        BigDecimal totalNum = BigDecimal.ZERO;
        if (items != null && items.size() > 0) {
            for (OrderItemTo item : items) {
                //計算當前商品的總價格
                BigDecimal itemPrice = item.getPrice().multiply(new BigDecimal(item.getCount().toString()));
                //再計算全部商品的總價格
                totalNum = totalNum.add(itemPrice);
            }
        }
        return totalNum;
    }
}

// 去結算確認頁
@GetMapping(value = "/toTrade")
public String toTrade(Model model, HttpServletRequest request) throws ExecutionException, InterruptedException {
    OrderConfirmVo confirmVo = orderService.confirmOrder();
    model.addAttribute("confirmOrderData", confirmVo);
    // 展示訂單確認的數據
    return "confirm";
}

/**
 * 訂單確認頁返回需要用的數據
 *
 * @return
 */
@Override
public OrderConfirmVo confirmOrder() throws ExecutionException, InterruptedException {
    // 構建OrderConfirmVo
    OrderConfirmVo confirmVo = new OrderConfirmVo();
    // 獲取當前用戶登入的信息
    MemberResponseTo memberResponseTo = LoginUserInterceptor.loginUser.get();
    // 獲取當前線程請求頭信息(解決Feign異步調用丟失請求頭問題)
    RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
    // 開啟第一個異步任務
    CompletableFuture<Void> addressFuture = CompletableFuture.runAsync(() -> {
        // 每一個線程都來共享之前的請求數據
        RequestContextHolder.setRequestAttributes(requestAttributes);
        // 遠程查詢所有的收貨地址列表
        List<MemberAddressTo> address = memberFeignService.getAddress(memberResponseTo.getId());
        confirmVo.setMemberAddressTos(address);
    }, threadPoolExecutor);

    // 開啟第二個異步任務
    CompletableFuture<Void> cartInfoFuture = CompletableFuture.runAsync(() -> {
        // 每一個線程都來共享之前的請求數據【解決異步ThreadLocal 無法共享數據】
        RequestContextHolder.setRequestAttributes(requestAttributes);
        // 遠程查詢購物車所有選中的購物項
        List<OrderItemTo> currentCartItems = cartFeignService.getCurrentCartItems();
        confirmVo.setItems(currentCartItems);
        // feign在遠程調用之前要構造請求，會調用很多的攔截器
    }, threadPoolExecutor).thenRunAsync(() -> {
        List<OrderItemTo> items = confirmVo.getItems();
        // 獲取全部商品的id
        List<Long> skuIds = items.stream()
                .map((itemVo -> itemVo.getSkuId()))
                .collect(Collectors.toList());

        // 遠程查詢商品庫存信息
        R skuHasStock = wareFeignService.getSkuHasStock(skuIds);
        List<SkuStockVo> skuStockVos = skuHasStock.getData("data", new TypeReference<List<SkuStockVo>>() {
        });

        if (skuStockVos != null && skuStockVos.size() > 0) {
            // 將skuStockVos集合轉換為map
            Map<Long, Boolean> skuHasStockMap =
                    skuStockVos.stream().collect(Collectors.toMap(SkuStockVo::getSkuId, SkuStockVo::getHasStock));
            confirmVo.setStocks(skuHasStockMap);
        }
    }, threadPoolExecutor);

    // 查詢用戶積分
    Integer integration = memberResponseTo.getIntegration();
    confirmVo.setIntegration(integration);

    // 價格數據計算寫在VO了

    // 防重令牌(防止表單重複提交)
    // 為用戶設置一個token，三十分鐘過期時間（存在redis）
    String token = UUID.randomUUID().toString().replace("-", "");
    redisTemplate.opsForValue().set(USER_ORDER_TOKEN_PREFIX + memberResponseTo.getId(), token, 30,
            TimeUnit.MINUTES);
    confirmVo.setOrderToken(token);

    CompletableFuture.allOf(addressFuture, cartInfoFuture).get();

    return confirmVo;
}

/**
 * feign攔截器功能
 * 解決feign 遠程請求頭丟失問題
 **/
@Configuration
public class FeignConfig {

    @Bean("requestInterceptor")
    public RequestInterceptor requestInterceptor() {

        RequestInterceptor requestInterceptor = new RequestInterceptor() {
            @Override
            public void apply(RequestTemplate template) {
                System.out.println("feign遠程調用，攔截包裝請求頭");

                // 使用RequestContextHolder拿到剛進來的請求數據
                ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
                if (requestAttributes != null) {
                    HttpServletRequest request = requestAttributes.getRequest();//老請求
                    if (request != null) {
                        // 同步請求頭的數據（主要是cookie）
                        // 把老請求的cookie值放到新請求上來，進行一個同步
                        String cookie = request.getHeader("Cookie");
                        template.header("Cookie", cookie);
                    }
                }
            }
        };
        return requestInterceptor;
    }
}

// 獲取當前線程請求頭信息(解決Feign異步調用丟失請求頭問題)
RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
// 開啟第一個異步任務
CompletableFuture<Void> addressFuture = CompletableFuture.runAsync(() -> {
    // 每一個線程都來共享之前的請求數據
    RequestContextHolder.setRequestAttributes(requestAttributes);
    // 遠程查詢所有的收貨地址列表
    List<MemberAddressTo> address = memberFeignService.getAddress(memberResponseTo.getId());
    confirmVo.setMemberAddressTos(address);
}, threadPoolExecutor);