新增

younger_times

2023-04-11 4356615a9252a987a62469331b1fcf91c102e24c

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
//
//  ForgotPasswordViewModel.swift
//  OKProject
//
//  Created by alvin_y on 2020/5/27.
//  Copyright © 2020 yangwang. All rights reserved.
//
 
import UIKit
import RxSwift
import RxCocoa
class ForgotPasswordViewModel: YYViewModel {
 
    /// 手机号
    let phoneNumber = BehaviorRelay<String>(value: "")
    
    /// 密码
    let password = BehaviorRelay<String>(value: "")
    
    /// 验证码
    let code = BehaviorRelay<String>(value: "")
    
    /// 发送验证码
    lazy var sendSMSCodeSubject = PublishSubject<RequestStatus>()
    
    /// 验证验证码
    lazy var checkCaptchaSubject = PublishSubject<RequestStatus>()
    
    /// 更新手机号
    lazy var updatePhoneSubject = PublishSubject<RequestStatus>()
    
    /// 忘记密码
    func forgotPassword()  {
        do {
            try phoneNumber.value.checkPhoneNumber()
            try code.value.checkSMSCode()
            try password.value.checkPassword()
            requestSubject.onNext(.loading)
            APIManager.shared.provider.rx
                .request(.forgetPassword(phone: phoneNumber.value, code: code.value, password: password.value))
                .map(YYModel<Nothing>.self)
                .validate()
                .subscribe(onSuccess: {[unowned self] (model) in
                    self.requestSubject.onNext(.success(nil))
                }) {[unowned self] (error) in
                    self.requestSubject.onNext(.error(error))
            }.disposed(by: disposeBag)
            
        } catch  {
            requestSubject.onNext(.error(error))
        }
    }
    
    /// 发送验证码
    func sendSMSCode(type: Int) {
        do {
            try phoneNumber.value.checkPhoneNumber()
            try phoneNumber.value.checkPhoneNumberBind()
            sendSMSCodeSubject.onNext(.loading)
            APIManager.shared.provider.rx
                .request(.queryCaptcha(phone: phoneNumber.value,type: type))
                .map(YYModel<Nothing>.self)
                .validate()
                .subscribe(onSuccess: { [weak self] (model) in
                    self?.sendSMSCodeSubject.onNext(.success(model))
                }) { (error) in
                    self.sendSMSCodeSubject.onNext(.error(error))
                }
                .disposed(by: disposeBag)
        } catch  {
            self.sendSMSCodeSubject.onNext(.error(error))
        }
        
    }
    
    /// 验证验证码
    func checkCaptcha()  {
        do {
            try code.value.checkSMSCode()
            checkCaptchaSubject.onNext(.loading)
            APIManager.shared.provider.rx
                .request(.checkCaptcha(phone: phoneNumber.value, code: code.value))
                .map(YYModel<CheckSMSCodeModel>.self)
                .validate()
                .subscribe(onSuccess: { [weak self] (model) in
                    guard let data = model.data else {return}
                    self?.checkCaptchaSubject.onNext(.success(data))
                }) { (error) in
                    self.checkCaptchaSubject.onNext(.error(error))
                }
                .disposed(by: disposeBag)
        } catch  {
            self.checkCaptchaSubject.onNext(.error(error))
        }
    }
    
    /// 更新手机号
    func updatePhone()  {
        do {
            try phoneNumber.value.checkPhoneNumber()
            try code.value.checkSMSCode()
            updatePhoneSubject.onNext(.loading)
            APIManager.shared.provider.rx
                .request(.updatePhone(phone: phoneNumber.value, code: code.value))
                .map(YYModel<CheckSMSCodeModel>.self)
                .validate()
                .subscribe(onSuccess: { [weak self] (model) in
                    guard let data = model.data else {return}
                    self?.updatePhoneSubject.onNext(.success(data))
                }) { (error) in
                    self.updatePhoneSubject.onNext(.error(error))
                }
                .disposed(by: disposeBag)
        } catch  {
            self.updatePhoneSubject.onNext(.error(error))
        }
    }
}