如何将这两个服务调用与一个单独的输出结果作为其他输入相结合？

如何解决如何将这两个服务调用与一个单独的输出结果作为其他输入相结合？

这是我的原始效果。它从服务调用中加载数据。

   getReviewEffect$ = createEffect(() => this.actions$.pipe(
    ofType(INIT),mergeMap(({ Id  }) => this.ReviewService.findByP(Id,new Date(new Date().setDate(new Date().getDate() -30)),new Date(new Date().setDate(new Date().getDate() + 30)),'Approval')
      .pipe(
        mergeMap(reviews => {
          return [ReviewLoadSuccess({ drugReviews: getReviews(reviews) })
          ];
        }),catchError(error => {
          return of(ReviewLoadFailure({ error: error }));
        })
      )
    )));

但是ID，我是在加载时调用此服务调用的。

this.ocService.getActiveoc().subscribe((oc => {
  this.Id = oc.id;
}));

我还需要将上面的代码放入我的效果中并进行初始加载。需要一些专家的帮助。并且还需要一种更好的方式来指定未来30天的日期。

--------------更新------------------------------ >

我尝试这样做，如下所示，但它已编译错误。需要一些专家帮助来解决它，

getReviewEffect$ = createEffect(() => this.actions$.pipe(
    ofType(INIT),mergeMap((Id)=> this.socService.getActiveoc().toPromise().thenoc=>{return oc.id})
    .then(((Id)=>{
      this.drugReviewService.findBy(Id,new Date(),new Date(new Date().setDate(new Date().getDate() + 1)),'Approval')
      .pipe(
        mergeMap(reviews => {
          return ReviewLoadSuccess({ Reviews: getReviews(reviews) })
          ];
        }),catchError(error => {
          return of(ReviewLoadFailure({ error: error }));
        })
      )
    })
    )))

解决方法

您可以尝试使用Promise()

this.ocService.getActiveoc().toPromise()
   .then(res => {this.Id = res['id']})
   .then(() => { 
      getReviewEffect$ = createEffect(() => this.actions$.pipe(
      ofType(INIT),mergeMap(({ Id  }) => this.ReviewService.findByP(Id,new Date(new                       
      Date().setDate(new Date().getDate() -30)),new Date(new Date().setDate(new Date().getDate() + 30)),'Approval')
      .pipe(
        mergeMap(reviews => {
          return [ReviewLoadSuccess({ drugReviews: getReviews(reviews) })
          ];
        }),catchError(error => {
          return of(ReviewLoadFailure({ error: error }));
        })
      )
    )));
 })