@RestController
@RequestMapping("/order")
public class OrderController {

    @Autowired
    private RestTemplate restTemplate;

    /**
     * 通过服务名完成调用
     */
    private final String URL_PREFIX = "http://PRODUCT-SERVICE/product/";

    /**
     * 暴露通过id远程查询product的接口
     * @param id
     * @return
     */
    @GetMapping("/product/{id}")
    public Product getProductById(@PathVariable("id") Long id){
        /**
         * 缺点：要拼接的地址很长
         */
        String url = URL_PREFIX + id;
        //以接口的方式进行调用
        return restTemplate.getForObject(url,Product.class);
    }
}

@FeignClient(value = "PRODUCT-SERVICE")    //里面所有的方法都要调用PRODUCT-SERVCIE这个服务
@RequestMapping("/product")
public interface ProductClient {
    /**
     * 回掉托底
     */
    @GetMapping("/{id}")
    public Product getProductById(@PathVariable(name = "id") Long id);
}

@RestController
@RequestMapping("/order")
public class OrderController {

    @Autowired
    private ProductClient productClient;

    /**
     * 暴露通过id远程查询product的接口
     * @param id
     * @return
     */
    @GetMapping("/product/{id}")
    public Product getProductById(@PathVariable("id") Long id){
        return productClient.getProductById(id);
    }
}

@RestController
@RequestMapping("/product")
public class ProductController {
    @Autowired
    private ProductService productService;

    /**
     * 根据id查询单条数据
     * @param id
     * @return
     */
    @GetMapping("/{id}")
    @HystrixCommand(fallbackMethod = "findOneFallback")
    public Product findOne(@PathVariable(name = "id") Long id) {
        //如果传入的id=2,报一个错让他熔断，其他的正常访问
        if (id.intValue() == 2){
            throw  new RuntimeException("报错了！");
        }
        Product product = productService.findOne(id);
        //为了查看是那个服务(端口运行得)
        product.setName(product.getName() + "-8003");
        return product;
    }

    private Product findOneFallback(Long id) {
        return new Product(id, "已经熔断啦...");
    }
}

/**
 * 这个工程类要给我们配一个ProductClient的托底类
 * @author Lenovo
 */
@Component
public class ProductClientFallbackFactory implements FallbackFactory<ProductClient> {

    /**
     * 里面就是返回托底类，里面要为每个方法都有一个托底方法
     * @param throwable
     * @return
     */
    @Override
    public ProductClient create(Throwable throwable) {
        return new ProductClient() {
            @Override
            public Product getProductById(Long id) {
                return new Product(id, "feign的托底方法");
            }
        };
    }
}

@Component
public class LoginFilter extends ZuulFilter {
    /**
     * 过滤器类型
     * - pre：请求在被路由之前执行
     *   - routing：在路由请求时调用
     *   - post：在routing和errror过滤器之后调用
     *   - error：处理请求时发生错误调用
     * @return
     */
    @Override
    public String filterType() {
        return "pre";
    }

    /**
     * 设置优先级，值越小越优先
     * @return
     */
    @Override
    public int filterOrder() {
        return 1;
    }

    /**
     * 是否执行本过滤器
     * @return
     */
    @Override
    public boolean shouldFilter() {
        return true;
    }

    /**
     * 过滤的逻辑
     * @return
     * @throws ZuulException
     */
    @Override
    public Object run() throws ZuulException {
        //获取上下文
        RequestContext currentContext = RequestContext.getCurrentContext();
        //获取请求
        HttpServletRequest request = currentContext.getRequest();
        //从请求头中获取token
        String token = request.getHeader("token");
        //判断是否登陆
        if (null == token || "".equals(token)) {
            //校验失败
            currentContext.setSendZuulResponse(false);
            //返回一个状态码401。也可以重定向
            currentContext.setResponseStatusCode(HttpStatus.SC_UNAUTHORIZED);
        }
        // 校验通过，可以考虑把用户信息放入上下文，继续向后执行
        return null;
    }
}