结合两个 API 将数据发送到后端

Question

我需要将带有两个 api 的单个表单发送到后端。我展示了一些代码作为参考。我只是展示有问题的部分。 我需要当用户点击提交表单时，首先它必须检查组织 ID 是否已经存在。如果存在则抛出错误消息。我的问题是当组织 ID 已经存在时，它不会抛出错误消息。如何实现它

服务

     public signupform(userData: SignupRequest): Observable<any>{
   let userid = userData.userId;

    return this.http.post('http://localhost:9080/project/api/auth/createorganisation')
    .pipe
    (tap( // Log the result or error
      data => {
        if (data.status['message'] === 'Success.') {

      switchMap(() => this.http.post('http://localhost:9080/project/api/auth/createuser')
      .pipe(catchError((error) => {return empty()}))

      )
        }else{
          throw new Error(data.status['message']);

        }
      },

    )
    )
  }

Answer 1

return this.http.post('http://localhost:9080/project/api/auth/createorganisation')
    .pipe(switchMap((data:any)=>{
          //you get the result
         if (data.status['message'] === 'Success.')
             return this.http.post('http://localhost:9080/project/api/auth/createuser')
         else 
           return throwError(data.status['message'])
    }))

好吧，如果创建用户可以返回 data.status['message'] === 'Success.'不管是不是，我们可以再做一个switchmap

return this.http.post('http://localhost:9080/project/api/auth/createorganisation')
     .pipe(switchMap((data:any)=>{
          //you get the result
         if (data.status['message'] === 'Success.')
             return this.http.post('http://localhost:9080/project/api/auth/createuser')
         .pipe(switchMap((data:any)=>{
             if (data.status['message'] === 'Success.')
                 return of(data)
             else
                 return throwError(data.status['message'])
         }))
         else 
           return throwError(data.status['message'])
    }))

看到我们使用了 throwError (a 'rxjs' create observable)，而不是新的错误

一般我们都喜欢订阅

this.service.signupform(data).susbcribe(
    (res)=>{console.log(res)},
    (error)=>{console.log(error)}
)

但您可以采取另一种方法，您所服务的总是返回一个值

return this.http.post('http://localhost:9080/project/api/auth/createorganisation')
     .pipe(switchMap((data:any)=>{
          //you get the result
         if (data.status['message'] === 'Success.')
             return this.http.post('http://localhost:9080/project/api/auth/createuser')
         .pipe(map((data:any)=>{
             if (!data.status['message'] === 'Success.')
                 return {error:data.status['message']}
         }))
         else 
           return of({error:data.status['message']})
    }),catchError((error)=>{
        return of({error:error})
    })

所以，你喜欢订阅

this.service.signupform(data).susbcribe(
    (res)=>{
      if (res.error){
         ....
      }
      else
        console.log(res)}
)