修改与新增

无故事王国

2023-05-25 dc1998fc1ac124f6b9a0e434ccf91103dd936409

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
//
//  SystemMessageViewModel.swift
//  OKProject
//
//  Created by alvin_y on 2020/6/17.
//  Copyright © 2020 yangwang. All rights reserved.
//
 
import UIKit
import RxCocoa
import RxSwift
 
class SystemMessageViewModel: YYRefreshViewModel<SystemMessageModel> {
    
    /// 下标
    let row = BehaviorRelay<Int>(value: 0)
    
    /// 消息Id
    let id  = BehaviorRelay<Int>(value: 0)
    
    /// 消息类型
    let type  = BehaviorRelay<Int>(value: 0)
    
    lazy var clearSystemNoticeSubject = PublishSubject<RequestStatus>()
    
    lazy var delSystemNoticeSubject = PublishSubject<RequestStatus>()
    
    lazy var queryNoReadNoticeNumSubject = PublishSubject<RequestStatus>()
    
    override func api() -> API! {
        return .systemNotice(type: type.value, pageNum: currentPage, size: totalPages)
    }
    
    /// 清除消息
    func clearSystemNotice()  {
        clearSystemNoticeSubject.onNext(.loading)
        APIManager.shared.provider.rx
            .request(.clearSystemNotice)
        .map(YYModel<Nothing>.self)
        .validate()
        .subscribe(onSuccess: { [unowned self] (model) in
            self.clearSystemNoticeSubject.onNext(.success(nil))
        }) {[unowned self] (error) in
            self.clearSystemNoticeSubject.onNext(.error(error))
        }
        .disposed(by: disposeBag)
    }
    
    /// 清除消息
    func delSystemNotice()  {
        delSystemNoticeSubject.onNext(.loading)
        APIManager.shared.provider.rx
            .request(.delSystemNotice(id: id.value))
        .map(YYModel<Nothing>.self)
        .validate()
        .subscribe(onSuccess: { [unowned self] (model) in
            self.delSystemNoticeSubject.onNext(.success(nil))
        }) {[unowned self] (error) in
            self.delSystemNoticeSubject.onNext(.error(error))
        }
        .disposed(by: disposeBag)
    }
    
    /// 查询未读消息
    func queryNoReadNoticeNum()  {
        queryNoReadNoticeNumSubject.onNext(.loading)
        APIManager.shared.provider.rx
            .request(.queryNoReadNoticeNum)
        .map(YYModel<NoticeNumModel>.self)
        .validate()
        .subscribe(onSuccess: { [unowned self] (model) in
            guard let data = model.data else {return}
            self.queryNoReadNoticeNumSubject.onNext(.success(data))
        }) {[unowned self] (error) in
            self.queryNoReadNoticeNumSubject.onNext(.error(error))
        }
        .disposed(by: disposeBag)
    }
}