javascript - Angular - 使用 mergeMap 从 2 个 API 获取数据并将它们保存在数组中

Question

场景:在 ngOnInit 上，我需要调用 3 个 API，对它们进行 Fork-Join 并将数据保存在数组中。第一个 API 是独立的。第 2 个也是独立的，但第 3 个依赖于第 2 个 API 的响应。

我以前没有使用过 forkjoin 或 mergemap，我有点困惑。

发生了什么:

我创建了一个通用方法，它采用标识符来确定要命中的端点以及具有所需参数的对象，然后进行响应和错误处理。

服务文件:

  callMethod(str, obj, cb?) {
    return new Observable(observer => {
      this.httpService.getHttpParams(this.URLS_CONSTANT[str], obj, res => {
        observer.next(res.data.content ? res.data.content : res.data);
        observer.complete();
      }, err => { })
    })

  }

因此，我能够从所有 3 个 API 获取响应，但 fork-join 后的最终结果包含第一个和第三个 API 的响应。缺少 2nd 的响应，我不知道发生了什么。

这是我写的方法:

  fetchAllData() {
    let inp = this.input_row;


    let response1 = this.service.callMethod('rate_plan', { companyId: inp.cpnyId, servAbbr: inp.servAbbr, productNumber: inp.prdctNo, orgNumber: inp.orgNo, rateCategory: inp.rateCat, ratePlanNumber: inp.ratePlanNo });

    let response2 = this.service.callMethod('approve_rate', { prodctNo: inp.prdctNo, servAbbr: inp.servAbbr, companyId: inp.cpnyId, ratePlanNo: inp.ratePlanNo }).pipe(map(item => {
        this.approveRate = item
        let appRate = item[0]
        return appRate
      }), mergeMap(data => this.service.callMethod('rate_detail', { companyId: inp.cpnyId, ratePlanNo: inp.ratePlanNo, rateCaseGrpngNo: data['rateCaseGrpngNo']})) )

      forkJoin([response1, response2]).subscribe(x => console.log(x))
  }

}

最终控制台具有 API 调用 1 和 3 的响应值。创建具有三个独立对象的数组需要进行哪些更改。如果需要更多说明，请告诉我。

Answer 1

您的方法很完美，但第二个响应可以通过 switchMap 运行以获得第三个响应，然后运行映射，以返回 secondResponse 的各个值> 和 thirdResponse 在数组中!

fetchAllData() {
    let inp = this.input_row;

    let response1 = this.service.callMethod('rate_plan', {
        companyId: inp.cpnyId,
        servAbbr: inp.servAbbr,
        productNumber: inp.prdctNo,
        orgNumber: inp.orgNo,
        rateCategory: inp.rateCat,
        ratePlanNumber: inp.ratePlanNo,
    });

    let response2 = this.service
        .callMethod('approve_rate', {
            prodctNo: inp.prdctNo,
            servAbbr: inp.servAbbr,
            companyId: inp.cpnyId,
            ratePlanNo: inp.ratePlanNo,
        })
        .pipe(
            switchMap(responsesecond => {
                this.approveRate = responsesecond;
                let appRate = responsesecond[0];
                return this.service
                    .callMethod('rate_detail', {
                        companyId: inp.cpnyId,
                        ratePlanNo: inp.ratePlanNo,
                        rateCaseGrpngNo: responsesecond['rateCaseGrpngNo'],
                    })
                    .pipe(
                        map(responsethird => {
                            return [responsesecond, responsethird];
                        })
                    );
            })
        );

    forkJoin([response1, response2]).subscribe(x => console.log(x));
}