使用 node.js 在 mongodb 中发布带有用户详细信息的数据

Question

我正在使用带有 Angular 6 的 MEAN 堆栈开发一个 Web 应用程序。我有一个表单可以将数据提交到 MongoDB。以下是保存功能，它可以工作。 它将挤出的值保存在数据库中。

saveExtrudedHeightValue(extrudedHeight: NgForm) {
  if (extrudedHeight.value != "" && extrudedHeight.value != null) {
    this.extrudedHeightService.saveExtrudedHeight(extrudedHeight.value).subscribe(res => {
      console.log(res);
    }, (err) => {
      console.log(err);
    });
  }
}

这是模型

// Schema for extruded height panel
var extrudedHeightSchema = new mongoose.Schema({
  userName: {
    type: String
  },
  extrudedHeight: {
    type: Number
  },

});
module.exports = mongoose.model('extrudedHeightValue', extrudedHeightSchema);

这是我的发帖路线

//post extrudedHeight values
router.post("/save", function(req, res) {
  var mod = new extrudedHeight(req.body);

  extrudedHeight.findOneAndUpdate({
      userName: req.body.email,
      extrudedHeight: req.body.extrudedHeight,
    },
    req.body, {
      upsert: true,
      new: true
    },
    function(err, data) {
      if (err) {
        console.log(err);
        res.send(err);
      } else {

        res.send(mod);
      }
    }
  );
});

这里是服务。

// service for save extruded height 
saveExtrudedHeight(extrudedHeight): Observable < any > {
  return this.http.post('/extrudedHeight/save', extrudedHeight, httpOptions)
    .pipe(
      catchError(this.handleError)
    );
}

现在我想用当前用户的userName 将数据保存在数据库中。我可以通过这个检索当前用户的userName。 this.payload.user['email'] 我的问题是我不知道如何通过此userName 发布路由以保存在数据库中。

这是我获得令牌的地方。

this.authService.onTokenChange().subscribe(
  (token: NbAuthJWTToken) => {
    if (token.isValid()) {
      this.user = token.getPayload().user;
      this.payload = token.getPayload();
      console.log(this.payload.user['email']);
    }
  }
)

Answer 1

您可以先在saveExtrudedHeight 方法内调用this.authService.onTokenChange，然后使用flatMap 运算符解开将由http.post 返回的内部Observable。

这将转化为这样的代码：

import { flatMap } from 'rxjs/operators';
import { throwError } from 'rxjs';

...

saveExtrudedHeight(extrudedHeight): Observable<any> {
  const requestPayload = {
    extrudedHeight
  };
  return this.authService.onTokenChange()
    .pipe(flatMap(
    (token: NbAuthJWTToken) => {
      if (token.isValid()) {
        this.user = token.getPayload().user;
        this.payload = token.getPayload();

        const email = this.payload.user['email'];
        requestPayload.email = email;

        // Make the changes here to send the email as the Request Payload.

        return this.http.post('/extrudedHeight/save', requestPayload, httpOptions)
          .pipe(
            catchError(this.handleError)
          );
      } else {
        throwError('Something went wrong!');
      }
    }
  ));
}

PS：我不确定这是否可行，因为我尚未对其进行测试，而且如果没有最低限度的 StackBlitz 工作，我就无法做到。