| | |
| | | |
| | | return |
| | | APIManager.shared.provider.rx |
| | | .request(.queryOrderInfo(orderId: orderId.value, orderType: orderType.value.parame())) |
| | | .request(.queryOrderInfo(orderId: orderId.value, orderType: orderType.value.rawValue)) |
| | | .mapThenValidate(YYSpecialCarModel.self) |
| | | .catchError { Single.just(.failure($0)) } |
| | | .asObservable() |
| | |
| | | /// 取消订单获取金额 |
| | | func queryCancleAmount() -> Observable<Result<CancleAmountModel?, Error>> { |
| | | return APIManager.shared.provider.rx |
| | | .request(.queryCancleAmount(id: orderId.value,orderType: orderType.value.parame())) |
| | | .request(.queryCancleAmount(id: orderId.value,orderType: orderType.value.rawValue)) |
| | | .mapThenValidate(CancleAmountModel.self) |
| | | .catchError { Single.just(.failure($0)) } |
| | | .asObservable() |
| | |
| | | func queryOrderServer() -> Observable<Result<SocketInfoModel?, Error>> { |
| | | return |
| | | APIManager.shared.provider.rx |
| | | .request(.queryOrderServer(orderId: self.orderId.value, orderType: orderType.value.parame())) |
| | | .request(.queryOrderServer(orderId: self.orderId.value, orderType: orderType.value.rawValue)) |
| | | .mapThenValidate(SocketInfoModel.self) |
| | | .catchError { Single.just(.failure($0)) } |
| | | .asObservable() |
| | |
| | | func queryEndPush() -> Observable<Result<SocketInfoModel?, Error>> { |
| | | return |
| | | APIManager.shared.provider.rx |
| | | .request(.queryEndPush(orderId: orderId.value, orderType: orderType.value.parame())) |
| | | .request(.queryEndPush(orderId: orderId.value, orderType: orderType.value.rawValue)) |
| | | .mapThenValidate(SocketInfoModel.self) |
| | | .catchError { Single.just(.failure($0)) } |
| | | .asObservable() |
| | |
| | | func pushOrder() -> Observable<Result<TravelServiceModel?, Error>> { |
| | | return |
| | | APIManager.shared.provider.rx |
| | | .request(.pushOrderTaxi(id: orderId.value, orderType: orderType.value.parame())) |
| | | .request(.pushOrderTaxi(id: orderId.value, orderType: orderType.value.rawValue)) |
| | | .mapThenValidate(TravelServiceModel.self) |
| | | .catchError { Single.just(.failure($0)) } |
| | | .asObservable() |
| | |
| | | func orderEvaluate() -> Observable<Result<Nothing?, Error>> { |
| | | return |
| | | APIManager.shared.provider.rx |
| | | .request(.orderEvaluate(orderId: self.orderId.value, orderType: orderType.value.parame(), fraction: fraction.value, content: content.value)) |
| | | .request(.orderEvaluate(orderId: self.orderId.value, orderType: orderType.value.rawValue, fraction: fraction.value, content: content.value)) |
| | | .mapThenValidate(Nothing.self) |
| | | .catchError { Single.just(.failure($0)) } |
| | | .asObservable() |
| | |
| | | func queryRedMoney() -> Observable<Result<CancleAmountModel?, Error>> { |
| | | return |
| | | APIManager.shared.provider.rx |
| | | .request(.queryRedMoney(orderId: orderId.value,orderType: orderType.value.parame())) |
| | | .request(.queryRedMoney(orderId: orderId.value,orderType: orderType.value.rawValue)) |
| | | .mapThenValidate(CancleAmountModel.self) |
| | | .catchError { Single.just(.failure($0)) } |
| | | .asObservable() |
| | |
| | | /// 评论成功后获取红包金额 |
| | | func shareRedEnvelope() -> Observable<Result<Nothing?, Error>> { |
| | | APIManager.shared.provider.rx |
| | | .request(.shareRedEnvelope(orderId: orderId.value, orderType: orderType.value.parame())) |
| | | .request(.shareRedEnvelope(orderId: orderId.value, orderType: orderType.value.rawValue)) |
| | | .mapThenValidate(Nothing.self) |
| | | .catchError { Single.just(.failure($0)) } |
| | | .asObservable() |