因為會忘,所以要寫下來

Angular 如何將多筆資料上傳後,取得全部回傳資料,再送到另一支 API

4 minutes to read

來回顧一下前幾天的日記文

Angular 圖片上傳之…日記文 程式碼流程規劃之…日記文

與今天介紹的內容有關,如何將多筆資料上傳後,取得全部回傳資料後 再將其資料整理,送到另一支 API 這次將會使用 RxJS 來做處理

情境

我有一筆訂單,裡面有許多的產品,需要先將產品上傳後,取得產品回傳後的 id,再將這些 id 塞到這筆訂單裡,此筆訂單才算完成。

狀況

因為是打 API,所以會有不同步的問題產生,首先必需要先克服這一點,才能繼續下一步


實作

假資料 API FakeStoreAPI

在 service 裡先建立兩支 post api 一支是 createProd 用來建立產品資料 另一搬是 createOrder 用來建立訂單資料

service.ts

createProd(data: any): Observable<any> {
  const url = `https://fakestoreapi.com/products`;
  const newData = JSON.stringify(data);
  return this.httpClient.post(url, newData, {
    headers: new HttpHeaders({
      'Content-Type': 'application/json',
    }),
  });
}

createOrder(data: any): Observable<any> {
  const url = `https://fakestoreapi.com/carts`;
  const newData = JSON.stringify(data);
  return this.httpClient.post(url, newData, {
    headers: new HttpHeaders({
      'Content-Type': 'application/json',
    }),
  });
}

在 template 裡做一個 submit 的按鈕

<button (click)="onSubmit()">Create Product In Cart</button>

建立預設傳入資料 .ts

products = [
  {
    title: 101,
    price: '11',
    quantity: 1,
  },
  {
    title: 102,
    price: '22',
    quantity: 35,
  },
  {
    title: 103,
    price: '33',
    quantity: 10,
  },
];

order = {
  userId: 5,
  date: new Date().toJSON(),
};

重頭戲來囉!!

.ts

onSubmit(): void {
  const maydata = {
    products: this.products,
    order: this.order,
  };

  of(maydata)
    .pipe(
      concatMap((data) => {
        const update$ = data.products.map((product) => {
          return this.appService.createProd(product).pipe(
            map((res) => {
              return {
                productId: res._id,
                quantity: product.quantity,
              };
            })
          );
        });
        return combineLatest(update$ as Array<Observable<any>>).pipe(
          map((d) => {
            const combineData = { ...data.order, products: d };
            return combineData;
          })
        );
      }),
      switchMap((data) => {
        return this.appService.createOrder(data);
      })
    )
    .subscribe();
}

如圖所示:


案例解說 (RxJs 連續技使用)

這裡我先將所有要傳入的資料包成一個物件,然後使用 rxjs 裡的 concatMap (註一)去處理產品上傳這部份, concatMap 的特性就是等所有資料都回傳回來後,才會進行下一步動作,接著再使用 combineLatest(註二) 的特性處理回傳回來後的資料,再使用 switchMap(註一),打一下筆 API

說起來簡單 但實際上若是不熟 RxJs 會卡蠻久的 (沒錯,我就是苦主之一 XDDD)


附錄

範例:https://stackblitz.com/edit/angular-ivy-qiwggq

註一:RxJS 轉換類型 Operators (2) - switchMap / concatMap / mergeMap / exhaustMap 註二:RxJS 組合/建立類型 Operators (2) - combineLatest / forkJoin / race

對這篇文章有什麼想法嗎?

Copyright © 2024 Mandy. All rights reserved. Build with Astro