登录失效拦截完善

fengxiang

2018-06-06 50223d066f7bb4446e47467463783b7f0170f889

 src/app/core/net/default.interceptor.ts

@@ -14,31 +14,46 @@
import { Subject } from 'rxjs/Subject';
import { error } from 'protractor';
import { debug } from 'util';
import {Location} from '@angular/common';

/**
 * 默认HTTP拦截器，其注册细节见 `app.module.ts`
 */
@Injectable()
export class DefaultInterceptor implements HttpInterceptor {
    private unLoginHandle: Subject<HttpErrorResponse> = new Subject<HttpErrorResponse>();
    // private unLoginHandle: Subject<HttpErrorResponse> = new Subject<HttpErrorResponse>();
    
    constructor(private injector: Injector) {
         this.unLoginHandle.debounceTime(100).subscribe(event => {
             if (!!event.error) {
                  let errorMsg = '';
                  const erroCode = <number>event.error['errorCode'];
                  switch (erroCode) {
                     case 10: errorMsg = '未登录,请登录'; break;
                     case 11: errorMsg = '登录过期,请重新登录'; break;
                     case 12: errorMsg = '账号过期,请联系供应商'; break;
                  }
                  this.model.info({
                    title: errorMsg,
                    onOk: () => this.goTo('/passport/login')
                  });
             }
         });
    }

    private isExpireModelShow = false;
    private unLoginHandle(event: HttpErrorResponse) {
        if (!!event.error) {
            let errorMsg = '';
            const erroCode =  !!event.error['errorCode'] ? Number.parseInt(event.error['errorCode']) : 0;
            switch (erroCode) {
               case 10: errorMsg = '未登录,请登录'; break;
               case 11: errorMsg = '登录过期,请重新登录'; break;
               case 12: errorMsg = '账号过期,请联系供应商'; break;
               case 0: errorMsg = '服务器处于离线状态'; break;
               default: errorMsg = '登录过期,请重新登录'; break;
            }
            if (!this.isExpireModelShow) {
                this.isExpireModelShow = true;
                // 清空refresh信息，不再刷新
                this.loginService.clearRefreshToken();
                this.model.info({
                  title: errorMsg,
                  onOk: () => {
                      this.isExpireModelShow = false;
                      this.goTo('/passport/login');
                  }
                });
            }
       }
    }
    get loginService(): LoginService {
        return this.injector.get<LoginService>(LoginService);
    }
    get msg(): NzMessageService {
        return this.injector.get(NzMessageService);
    }
@@ -53,7 +68,8 @@
        // 可能会因为 `throw` 导出无法执行 `_HttpClient` 的 `end()` 操作
        // this.injector.get(_HttpClient).end();
        // 业务处理：一些通用操作
        switch (event.status) {
        const status = !!event.status ? event.status : 401;
        switch (status) {
            case 200:
                // 业务层级错误处理，以下假如响应体的 `status` 若不为 `0` 表示业务级异常
                // 并显示 `error_message` 内容
@@ -68,7 +84,9 @@
                break;
            case 401: // 未登录状态码
            // this.goTo('/passport/login');
                this.unLoginHandle.next(<HttpErrorResponse>event);
                if (!this.isLoginPage) {
                    this.unLoginHandle(<HttpErrorResponse>event);
                }
                break;
            case 403:
            case 404:
@@ -83,13 +101,11 @@
            return of(event);
        }       
    }

    private get isLoginPage(): boolean {
        return !!location && !!location.hash && location.hash.endsWith('login');
    }
    intercept(req: HttpRequest<any>, next: HttpHandler):
        Observable<HttpSentEvent | HttpHeaderResponse | HttpProgressEvent | HttpResponse<any> | HttpUserEvent<any>> {
        if (!req.headers.get('X-Refrsh-Token')) {
            const loginService = <LoginService>this.injector.get(LoginService);
            loginService.refreshToken();
        }        
        Observable<HttpSentEvent | HttpHeaderResponse | HttpProgressEvent | HttpResponse<any> | HttpUserEvent<any>> {       
        // 统一加上服务端前缀
        let url = req.url;
        if (!url.startsWith('https://') && !url.startsWith('http://') && !url.startsWith('assets')) {
@@ -103,12 +119,22 @@
        return next.handle(newReq).pipe(
                    mergeMap((event: any) => {                        
                        // 允许统一对请求错误处理，这是因为一个请求若是业务上错误的情况下其HTTP请求的状态是200的情况下需要
                        if (event instanceof HttpResponse && event.status === 200)
                            return this.handleData(event);
                        if (event instanceof HttpResponse && event.status === 200) {
                                // 刷新token的请求，不设置刷新
                                if (!this.isLoginPage 
                                    && !!newReq.headers 
                                    && !newReq.headers.get('X-Refrsh-Token')
                                    && !url.startsWith('assets')) {                                    
                                    this.loginService.refreshToken();
                                } 
                                return this.handleData(event);
                            }
                        // 若一切都正常，则后续操作
                        return of(event);
                    }),
                    catchError((err: HttpErrorResponse) => this.handleData(err))
                    catchError((err: HttpErrorResponse) => {
                        return this.handleData(err);
                    })
                );
    }
}