From 032ca75e238cc2f2a96b3bf27532b5a243d9a24a Mon Sep 17 00:00:00 2001
From: 沈斌 <bluelazysb@hotmail.com>
Date: Tue, 13 Mar 2018 16:00:41 +0800
Subject: [PATCH] 工作台数据统计页面
---
src/app/core/net/default.interceptor.ts | 92 ++++++++++++++++++++++++++++------------------
1 files changed, 56 insertions(+), 36 deletions(-)
diff --git a/src/app/core/net/default.interceptor.ts b/src/app/core/net/default.interceptor.ts
index 646fd59..33a9917 100644
--- a/src/app/core/net/default.interceptor.ts
+++ b/src/app/core/net/default.interceptor.ts
@@ -1,14 +1,16 @@
import { Injectable, Injector } from '@angular/core';
import { Router } from '@angular/router';
-import { HttpInterceptor, HttpRequest, HttpHandler,
+import { HttpInterceptor, HttpRequest, HttpHandler, HttpErrorResponse,
HttpSentEvent, HttpHeaderResponse, HttpProgressEvent, HttpResponse, HttpUserEvent,
} from '@angular/common/http';
import { Observable } from 'rxjs/Observable';
+import { of } from 'rxjs/observable/of';
import { ErrorObservable } from 'rxjs/observable/ErrorObservable';
-import { catchError } from 'rxjs/operators';
-import { map, mergeMap } from 'rxjs/operators';
-
-import { environment } from '../../../environments/environment';
+import { mergeMap, catchError } from 'rxjs/operators';
+import { NzMessageService } from 'ng-zorro-antd';
+import { _HttpClient } from '@delon/theme';
+import { environment } from '@env/environment';
+import { LoginService } from '@business/services/http/login.service';
/**
* ������HTTP������������������������������ `app.module.ts`
@@ -17,17 +19,54 @@
export class DefaultInterceptor implements HttpInterceptor {
constructor(private injector: Injector) {}
- private goLogin() {
- const router = this.injector.get(Router);
- this.injector.get(Router).navigate([ '/login' ]);
+ get msg(): NzMessageService {
+ return this.injector.get(NzMessageService);
+ }
+
+ private goTo(url: string) {
+ setTimeout(() => this.injector.get(Router).navigateByUrl(url));
+ }
+
+ private handleData(event: HttpResponse<any> | HttpErrorResponse): Observable<any> {
+ // ��������������� `throw` ������������������ `_HttpClient` ��� `end()` ������
+ // this.injector.get(_HttpClient).end();
+ // ���������������������������������
+ switch (event.status) {
+ case 200:
+ // ��������������������������������������������������� `status` ��������� `0` ���������������������
+ // ��������� `error_message` ������
+
+ // const body: any = event instanceof HttpResponse && event.body;
+ // if (body && body.status !== 0) {
+ // this.msg.error(body.error_message);
+ // // ������������������������������������ Pipe���subscribe ������������������
+ // // this.http.get('/').subscribe() ���������������
+ // return ErrorObservable.throw(event);
+ // }
+ break;
+ case 401: // ������������������
+ this.goTo('/passport/login');
+ break;
+ case 403:
+ case 404:
+ case 500:
+ this.goTo(`/${event.status}`);
+ break;
+ }
+ // ��������������������� httpclient ������������
+ if (event instanceof HttpErrorResponse) {
+ return ErrorObservable.create(event);
+ } else {
+ return of(event);
+ }
}
intercept(req: HttpRequest<any>, next: HttpHandler):
Observable<HttpSentEvent | HttpHeaderResponse | HttpProgressEvent | HttpResponse<any> | HttpUserEvent<any>> {
-
- // TIPS������TOKEN��������������� `@delon/auth` ������
- // Document: http://ng-alain.com/docs/auth
-
+ if (!req.headers.get('X-Refrsh-Token')) {
+ const loginService = <LoginService>this.injector.get(LoginService);
+ loginService.refreshToken();
+ }
// ���������������������������
let url = req.url;
if (!url.startsWith('https://') && !url.startsWith('http://')) {
@@ -37,34 +76,15 @@
const newReq = req.clone({
url: url
});
-
return next.handle(newReq).pipe(
- mergeMap((event: any) => {
+ mergeMap((event: any) => {
// ������������������������������������������������������������������������������������������������HTTP������������������200������������������
- if (event instanceof HttpResponse && event.status !== 200) {
- // ���������������observer.error ��������������������� `catch`
- // return ErrorObservable.create(event);
- }
+ if (event instanceof HttpResponse && event.status === 200)
+ return this.handleData(event);
// ������������������������������������
- return Observable.create(observer => observer.next(event));
+ return of(event);
}),
- catchError((res: HttpResponse<any>) => {
- // ���������������������������������
- switch (res.status) {
- case 401: // ������������������
- this.goLogin();
- break;
- case 200:
- // ������������������������
- console.log('������������');
- break;
- case 404:
- // 404
- break;
- }
- // ������������������������������������
- return ErrorObservable.create(event);
- })
+ catchError((err: HttpErrorResponse) => this.handleData(err))
);
}
}
--
Gitblit v1.8.0