scala - 在 Play 2.5 和 ReactiveMongo 中处理更新失败

Question

我编写了简单的rest API，它将音乐曲目数据添加到mongodb。

我能够成功写入轨道，但是我想处理错误情况。

我的代码如下 -

  def saveTrack = Action.async(parse.json) { 
     import model.Track.trackFormat
     implicit request =>
    request.body.validate[Track].map { data =>
      trackService.save(data).onComplete {
        case Success(value) => Ok(Json.obj("message" -> Messages("track.save.ack")))
        case Failure(e) => Ok(Json.obj("message" -> Messages("track.save.nack")))
    }
    }
    Future.successful(Ok(Json.obj("message" -> Messages("track.save.fin"))))
  }

让我们假设 trackService.save(data) 发生了一些故障，然后我想返回错误代码。我想知道如何实现这一目标。

谢谢帕里

Answer 1

def saveTrack = Action.async(parse.json) { implicit request =>
    request
      .body
      .validate[Track]
      .map { data =>
        trackService.save(data).map { v =>
          Ok(Json.toJson(Json.obj("message" -> Messages("ack"))))
        }.recover {
          case _ =>
            Ok(Json.toJson(Json.obj("message" -> Messages("nack"))))
        }
      }.getOrElse {Future.successful(BadRequest(Json.obj("error" -> "bad json")))
    }
  }

用于recover处理错误，getOrElse以防 json 正文与您的模型不匹配。