| | |
| | | func queryTrack() { |
| | | queryTrackSubject.onNext(.loading) |
| | | APIManager.shared.provider.rx |
| | | .request(.queryTrack(orderId: orderId.value, orderType: orderType.value.parame())) |
| | | .request(.queryTrack(orderId: orderId.value, orderType: orderType.value.rawValue)) |
| | | .map(YYModel<[TrackModel]>.self) |
| | | .validate() |
| | | .subscribe(onSuccess: { [unowned self] (model) in |
| | |
| | | /// 获取详情 |
| | | func queryOrderInfo() { |
| | | APIManager.shared.provider.rx |
| | | .request(.queryOrderInfo(orderId: orderId.value, orderType: orderType.value.parame())) |
| | | .request(.queryOrderInfo(orderId: orderId.value, orderType: orderType.value.rawValue)) |
| | | .map(YYModel<TravelServiceModel>.self) |
| | | .validate() |
| | | .subscribe(onSuccess: { (model) in |
| | |
| | | func cancleOrderTaxi() { |
| | | cancleOrderTaxiSubject.onNext(.loading) |
| | | APIManager.shared.provider.rx |
| | | .request(.cancleOrderTaxi(cancleId: cancelId.value, id: orderId.value,orderType: orderType.value.parame(), payType: payType.value)) |
| | | .request(.cancleOrderTaxi(cancleId: cancelId.value, id: orderId.value,orderType: orderType.value.rawValue, payType: payType.value)) |
| | | .map(YYModel<PayModel>.self) |
| | | .validate() |
| | | .subscribe(onSuccess: { [unowned self] (model) in |
| | |
| | | func addCancle() { |
| | | addCancleSubject.onNext(.loading) |
| | | APIManager.shared.provider.rx |
| | | .request(.addCancle(id: orderId.value, orderType: orderType.value.parame(), reason: reason.value, remark: remark.value)) |
| | | .request(.addCancle(id: orderId.value, orderType: orderType.value.rawValue, reason: reason.value, remark: remark.value)) |
| | | .map(YYModel<SystemMessageModel>.self) |
| | | .validate() |
| | | .subscribe(onSuccess: { [unowned self] (model) in |
| | |
| | | /// 获取司机位置 |
| | | func queryOrderServer() { |
| | | APIManager.shared.provider.rx |
| | | .request(.queryOrderServer(orderId: self.orderId.value, orderType: orderType.value.parame())) |
| | | .request(.queryOrderServer(orderId: self.orderId.value, orderType: orderType.value.rawValue)) |
| | | .map(YYModel<SocketInfoModel>.self) |
| | | .validate() |
| | | .subscribe(onSuccess: { (model) in |
| | | guard let data = model.data else{return} |
| | | if data.orderType == self.orderType.value.parame(){ |
| | | if data.orderType == self.orderType.value.rawValue{ |
| | | self.driverInfo.accept(data) |
| | | } |
| | | }) { (error) in |
| | |
| | | func orderEvaluate() { |
| | | evaluateSubject.onNext(.loading) |
| | | 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)) |
| | | .map(YYModel<Nothing>.self) |
| | | .validate() |
| | | .subscribe(onSuccess: {[unowned self] (model) in |
| | |
| | | func queryRedMoney() { |
| | | queryRedMoneySubject.onNext(.loading) |
| | | APIManager.shared.provider.rx |
| | | .request(.queryRedMoney(orderId: orderId.value, orderType: orderType.value.parame())) |
| | | .request(.queryRedMoney(orderId: orderId.value, orderType: orderType.value.rawValue)) |
| | | .map(YYModel<CancleAmountModel>.self) |
| | | .validate() |
| | | .subscribe(onSuccess: {[unowned self] (model) in |
| | |
| | | func pushOrderTaxi() { |
| | | pushOrderTaxiTaxiSubject.onNext(.loading) |
| | | APIManager.shared.provider.rx |
| | | .request(.pushOrderTaxi(id: orderId.value,orderType: orderType.value.parame())) |
| | | .request(.pushOrderTaxi(id: orderId.value,orderType: orderType.value.rawValue)) |
| | | .map(YYModel<TravelServiceModel>.self) |
| | | .validate() |
| | | .subscribe(onSuccess: { [unowned self] (model) in |
| | |
| | | func queryCancleAmount() { |
| | | queryCancleAmountSubject.onNext(.loading) |
| | | APIManager.shared.provider.rx |
| | | .request(.queryCancleAmount(id: orderId.value,orderType: orderType.value.parame())) |
| | | .request(.queryCancleAmount(id: orderId.value,orderType: orderType.value.rawValue)) |
| | | .map(YYModel<CancleAmountModel>.self) |
| | | .validate() |
| | | .subscribe(onSuccess: { [unowned self] (model) in |
| | |
| | | func shareRedEnvelope() { |
| | | shareRedEnvelopeSubject.onNext(.loading) |
| | | APIManager.shared.provider.rx |
| | | .request(.shareRedEnvelope(orderId: orderId.value, orderType: orderType.value.parame())) |
| | | .request(.shareRedEnvelope(orderId: orderId.value, orderType: orderType.value.rawValue)) |
| | | .map(YYModel<Nothing>.self) |
| | | .validate() |
| | | .subscribe(onSuccess: {[unowned self] (model) in |
| | |
| | | func completeOrder() { |
| | | completeOrderSubject.onNext(.loading) |
| | | APIManager.shared.provider.rx |
| | | .request(.completeOrder(orderId: orderId.value, orderType: orderType.value.parame())) |
| | | .request(.completeOrder(orderId: orderId.value, orderType: orderType.value.rawValue)) |
| | | .map(YYModel<Nothing>.self) |
| | | .validate() |
| | | .subscribe(onSuccess: {[unowned self] (model) in |
| | |
| | | func queryEndPush() { |
| | | queryEndPushSubject.onNext(.loading) |
| | | APIManager.shared.provider.rx |
| | | .request(.queryEndPush(orderId: orderId.value, orderType: orderType.value.parame())) |
| | | .request(.queryEndPush(orderId: orderId.value, orderType: orderType.value.rawValue)) |
| | | .map(YYModel<SocketInfoModel>.self) |
| | | .validate() |
| | | .subscribe(onSuccess: {[unowned self] (model) in |