airport-chengdu-web/src/app/services/http-client.service.ts

import { Injectable } from '@angular/core';
import { HttpClient, HttpRequest, HttpHeaders, HttpParams } from '@angular/common/http';
import { HttpObserve } from '@angular/common/http/src/client';

import { Observable } from 'rxjs';

/**
 * httpclient服务
 */
@Injectable()
export class HttpClientService {

    constructor(
        private httpClient: HttpClient,
    ) { }



    /**
     * request
     *
     * @return any
     */
    request(method: string, url: string, options?): Observable<any> {
        return this.commonProcess(this.httpClient.request(method, url, options));
    }



    /**
   * delete
   * @param url 
   * @param options 
   */
    delete(url: string, options?): Observable<any> {
        return this.commonProcess(this.httpClient.delete(url, options));
    }

    /**
   * get
   * @param url 
   * @param options 
   */
    get(url: string, params?: object, options?): Observable<any> {
        let paramsString = [];
        url = url + '?'
        let t = Math.random();
        if (params && params) {
            for (const key in params) {
                if (params[key] !== '') {
                    paramsString.push([key, params[key]].join('='))
                }
            }
            return this.commonProcess(this.httpClient.get(encodeURI(url + paramsString.join('&') + '&t=' + t), options));
        } else {
            return this.commonProcess(this.httpClient.get(url + 't=' + t, options));
        }
    }

    /**
     * head
     * @param url 
     * @param options 
     */
    head(url: string, options?): Observable<any> {
        return this.commonProcess(this.httpClient.head(url, options));
    }

    /**
    * options
    * @param url 
    * @param options 
    */
    options(url: string, options?): Observable<any> {
        return this.commonProcess(this.httpClient.options(url, options));
    }

    /**
    * patch
    * @param url 
    * @param options 
    */
    patch(url: string, body?, options?): Observable<any> {
        return this.commonProcess(this.httpClient.patch(url, body, options));
    }


    /**
    * post
    * @param url 
    * @param body
    * @param options 
    */
    post(url: string, body?, options?): Observable<any> {
        return this.commonProcess(this.httpClient.post(url, body, options));
    }

    /**
    * put
    * @param url 
    * @param options 
    */
    put(url: string, body?, options?): Observable<any> {
        return this.commonProcess(this.httpClient.put(url, body, options));
    }

    /**
     * 公共处理
     * @param observable 
     */
    commonProcess(observable: Observable<any>): Observable<any> {
        return Observable.create((observer) => {
            observable.subscribe(res => {
                observer.next(res);
            }, (err) => {
                observer.error(err);
            }, () => {
                observer.complete();
            });
        });
    }

}