Moya+ObjectMapper+MJRefresh构建网络请求和刷新

Author: 田全军

RxSwift-Table-Collection1/.DS_Store

@@ -21,6 +21,9 @@
 		4705E0BC1F6CBF970063F566 /* InputValidator.swift in Sources */ = {isa = PBXBuildFile; fileRef = 4705E0BB1F6CBF970063F566 /* InputValidator.swift */; };
 		4705E0BE1F6CC1430063F566 /* ResultProtocol.swift in Sources */ = {isa = PBXBuildFile; fileRef = 4705E0BD1F6CC1430063F566 /* ResultProtocol.swift */; };
 		4705E0C21F6CD6EB0063F566 /* RegisterViewModel.swift in Sources */ = {isa = PBXBuildFile; fileRef = 4705E0C11F6CD6EB0063F566 /* RegisterViewModel.swift */; };
+		4726CBB91F7E675B0050E6BE /* ObservableObjectMapper.swift in Sources */ = {isa = PBXBuildFile; fileRef = 4726CBB81F7E675B0050E6BE /* ObservableObjectMapper.swift */; };
+		4726CBBB1F7E6B330050E6BE /* ReponseObjectMapper.swift in Sources */ = {isa = PBXBuildFile; fileRef = 4726CBBA1F7E6B330050E6BE /* ReponseObjectMapper.swift */; };
+		4726CBBD1F7F337E0050E6BE /* BaseViewModel.swift in Sources */ = {isa = PBXBuildFile; fileRef = 4726CBBC1F7F337E0050E6BE /* BaseViewModel.swift */; };
 		474136161F6FE0240069902B /* RxTableViewController.swift in Sources */ = {isa = PBXBuildFile; fileRef = 474136141F6FE0240069902B /* RxTableViewController.swift */; };
 		474136171F6FE0240069902B /* RxTableViewController.xib in Resources */ = {isa = PBXBuildFile; fileRef = 474136151F6FE0240069902B /* RxTableViewController.xib */; };
 		4741361B1F6FFA120069902B /* AnchorViewModel.swift in Sources */ = {isa = PBXBuildFile; fileRef = 4741361A1F6FFA120069902B /* AnchorViewModel.swift */; };
@@ -52,6 +55,9 @@
 		4705E0BB1F6CBF970063F566 /* InputValidator.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = InputValidator.swift; sourceTree = "<group>"; };
 		4705E0BD1F6CC1430063F566 /* ResultProtocol.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = ResultProtocol.swift; sourceTree = "<group>"; };
 		4705E0C11F6CD6EB0063F566 /* RegisterViewModel.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = RegisterViewModel.swift; sourceTree = "<group>"; };
+		4726CBB81F7E675B0050E6BE /* ObservableObjectMapper.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = ObservableObjectMapper.swift; sourceTree = "<group>"; };
+		4726CBBA1F7E6B330050E6BE /* ReponseObjectMapper.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = ReponseObjectMapper.swift; sourceTree = "<group>"; };
+		4726CBBC1F7F337E0050E6BE /* BaseViewModel.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = BaseViewModel.swift; sourceTree = "<group>"; };
 		474136141F6FE0240069902B /* RxTableViewController.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = RxTableViewController.swift; sourceTree = "<group>"; };
 		474136151F6FE0240069902B /* RxTableViewController.xib */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = file.xib; path = RxTableViewController.xib; sourceTree = "<group>"; };
 		4741361A1F6FFA120069902B /* AnchorViewModel.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = AnchorViewModel.swift; sourceTree = "<group>"; };
@@ -162,6 +168,7 @@
 			children = (
 				4741361A1F6FFA120069902B /* AnchorViewModel.swift */,
 				4741361C1F70A86E0069902B /* NetworkTools.swift */,
+				4726CBBC1F7F337E0050E6BE /* BaseViewModel.swift */,
 			);
 			path = ViewModels;
 			sourceTree = "<group>";
@@ -221,6 +228,15 @@
 			path = Views;
 			sourceTree = "<group>";
 		};
+		4726CBB51F7E64E90050E6BE /* Tools */ = {
+			isa = PBXGroup;
+			children = (
+				4726CBB81F7E675B0050E6BE /* ObservableObjectMapper.swift */,
+				4726CBBA1F7E6B330050E6BE /* ReponseObjectMapper.swift */,
+			);
+			path = Tools;
+			sourceTree = "<group>";
+		};
 		474136221F70A8F40069902B /* Model */ = {
 			isa = PBXGroup;
 			children = (
@@ -250,6 +266,7 @@
 		6A0DF5B11F6C0CFC002827B3 /* RxSwift-Table-Collection */ = {
 			isa = PBXGroup;
 			children = (
+				4726CBB51F7E64E90050E6BE /* Tools */,
 				4705E0941F6CB8660063F566 /* 登录注册 */,
 				4705E0991F6CB8660063F566 /* UICollectionView */,
 				4705E09E1F6CB8660063F566 /* UITableView */,
@@ -432,16 +449,19 @@
 			files = (
 				4741361D1F70A86E0069902B /* NetworkTools.swift in Sources */,
 				474136241F70A8FF0069902B /* AnchorModel.swift in Sources */,
+				4726CBB91F7E675B0050E6BE /* ObservableObjectMapper.swift in Sources */,
 				4705E0B91F6CB9820063F566 /* RegisterViewController.swift in Sources */,
 				4705E0A71F6CB8AA0063F566 /* RxCollectionViewController.swift in Sources */,
 				4705E0B11F6CB8D60063F566 /* RxTableViewCell.swift in Sources */,
 				474136161F6FE0240069902B /* RxTableViewController.swift in Sources */,
 				474136271F70A9B70069902B /* RxCollectionViewCell.swift in Sources */,
 				6A0DF5B51F6C0CFC002827B3 /* ViewController.swift in Sources */,
 				4705E0BC1F6CBF970063F566 /* InputValidator.swift in Sources */,
+				4726CBBB1F7E6B330050E6BE /* ReponseObjectMapper.swift in Sources */,
 				4741361B1F6FFA120069902B /* AnchorViewModel.swift in Sources */,
 				4705E0B51F6CB9530063F566 /* LoginViewController.swift in Sources */,
 				6A0DF5B31F6C0CFC002827B3 /* AppDelegate.swift in Sources */,
+				4726CBBD1F7F337E0050E6BE /* BaseViewModel.swift in Sources */,
 				4705E0C21F6CD6EB0063F566 /* RegisterViewModel.swift in Sources */,
 				4705E0BE1F6CC1430063F566 /* ResultProtocol.swift in Sources */,
 				4705E0AE1F6CB8C90063F566 /* HeroViewModel.swift in Sources */,
@@ -519,6 +539,7 @@
 				SWIFT_ACTIVE_COMPILATION_CONDITIONS = DEBUG;
 				SWIFT_OPTIMIZATION_LEVEL = "-Onone";
 				TARGETED_DEVICE_FAMILY = "1,2";
+				USER_HEADER_SEARCH_PATHS = "";
 			};
 			name = Debug;
 		};
@@ -562,6 +583,7 @@
 				SDKROOT = iphoneos;
 				SWIFT_OPTIMIZATION_LEVEL = "-Owholemodule";
 				TARGETED_DEVICE_FAMILY = "1,2";
+				USER_HEADER_SEARCH_PATHS = "";
 				VALIDATE_PRODUCT = YES;
 			};
 			name = Release;

RxSwift-Table-Collection1/RxSwift-Table-Collection.xcodeproj/project.pbxproj

@@ -11,6 +11,6 @@
 
 //Libs使用cocoaPods集成
 #import "MJRefresh.h"
-#import "SVProgressHUD"
+#import "SVProgressHUD.h"
 
 #endif /* RxSwift_Bridging_Header_h */

RxSwift-Table-Collection1/RxSwift-Table-Collection/.DS_Store

@@ -0,0 +1,67 @@
+//
+//  ObservableObjectMapper.swift
+//  RxSwiftMoyaDemo
+//
+//  Created by iOS_Tian on 2017/9/29.
+//  Copyright © 2017年 iOS_Tian. All rights reserved.
+//
+
+import Foundation
+import RxSwift
+import Moya
+import ObjectMapper
+
+/*
+extension Observable {
+    //1. 单个对象的处理
+    public func mapObject<T: Mappable>(type: T.Type) -> Observable<T> {
+        return self.map({ response in
+            
+            //1-1. 如果response是一个字典,就用ObjectMapper映射这个字典
+            guard let dict = response as? [String: Any] else {
+                //1-2. 如果不是字典就抛出一个错误
+                throw NetworkRequestState.jsonError
+            }
+            
+            //2. 返回模型数组
+            return Mapper<T>().map(JSON: dict)!
+        })
+    }
+    
+    //2. 对象数组的处理
+    public func mapObjectArray<T: Mappable>(type: T.Type) -> Observable<[T]> {
+        return self.map({ response in
+            
+            //2-0. 先判断返回类型是不是一个对象
+            guard let array = response as? [String: Any] else {
+                throw NetworkRequestState.jsonError
+            }
+            
+            //2-1. 判断返回类型是不是一个对象
+            guard let anchors = array["message"] as? [String: Any] else {
+                throw NetworkRequestState.jsonError
+            }
+            
+            //2-1. 如果response是一个字典数组,就用ObjectMapper映射这个数组
+            guard let dictArr = anchors["anchors"] as? [[String: Any]] else {
+                //2-2. 如果不是字典就抛出一个错误
+                throw NetworkRequestState.jsonError
+            }
+            
+            //3. 返回模型数组
+            return Mapper<T>().mapArray(JSONArray: dictArr)
+        })
+    }
+}
+
+
+
+//请求错误显示信息
+enum NetworkRequestState: String {
+    case jsonError = "解析错误"
+    case OtherError
+}
+
+extension NetworkRequestState : Error {}
+*/
+

RxSwift-Table-Collection1/RxSwift-Table-Collection/RxSwift-Bridging-Header.h

@@ -0,0 +1,67 @@
+//
+//  ReponseObjectMapper.swift
+//  RxSwift-Table-Collection
+//
+//  Created by iOS_Tian on 2017/9/29.
+//  Copyright © 2017年 Quanjun. All rights reserved.
+//
+
+import Foundation
+import RxSwift
+import Moya
+import ObjectMapper
+
+// MARK: - Json -> Model
+extension Response {
+    // 1. 将Json解析为单个Model
+    public func mapObject<T: BaseMappable>(_ type: T.Type) throws -> T {
+        //1-1. 如果mapJSON()是一个字典,就用ObjectMapper映射这个字典
+        guard let object = Mapper<T>().map(JSONObject: try mapJSON()) else {
+            throw MoyaError.jsonMapping(self)
+        }
+        
+        //1-2. 返回映射的model
+        return object
+    }
+    
+    
+    // 2. 将Json解析为多个Model，返回数组，对于不同的json格式需要对该方法进行修改
+    public func mapObjectArray<T: BaseMappable>(_ type: T.Type) throws -> [T] {
+        //2-0. 先判断返回类型是不是一个字典
+        guard let array = try mapJSON() as? [String: Any] else {
+            throw MoyaError.jsonMapping(self)
+        }
+        
+        //2-1. 判断返回类型是不是一个对象
+        guard let anchors = array["message"] as? [String: Any] else {
+            throw MoyaError.jsonMapping(self)
+        }
+        
+        //2-1. 如果response是一个字典数组,就用ObjectMapper映射这个数组
+        guard let dictArr = anchors["anchors"] as? [[String: Any]] else {
+            //2-2. 如果不是字典就抛出一个错误
+            throw MoyaError.jsonMapping(self)
+        }
+        
+        //2-3. 返回model数组
+        return Mapper<T>().mapArray(JSONArray: dictArr)
+    }
+}
+
+
+// MARK: - Json -> Observable<Model>
+extension ObservableType where E == Response {
+    // 1. 将Json解析为Observable<Model>(单个model)
+    public func mapObject<T: BaseMappable>(_ type: T.Type) -> Observable<T> {
+        return flatMap({ (response) -> Observable<T> in
+            return Observable.just(try response.mapObject(T.self))
+        })
+    }
+    
+    //2.将Json解析为Observable<[Model]>(数组)
+    public func mapObjectArray<T: BaseMappable>(_ type: T.Type) -> Observable<[T]> {
+        return flatMap({ (response) -> Observable<[T]> in
+            return Observable.just(try response.mapObjectArray(T.self))
+        })
+    }
+}

RxSwift-Table-Collection1/RxSwift-Table-Collection/Tools/ObservableObjectMapper.swift

@@ -9,6 +9,7 @@
 import UIKit
 import RxSwift
 import RxCocoa
+import RxDataSources
 
 
 fileprivate let kCollecCellID: String = "collecCell"
@@ -27,31 +28,58 @@ class RxCollectionViewController: UIViewController {
         //0.加载collectionViewCell
         collectionVIew.register(UINib(nibName: "RxCollectionViewCell", bundle: nil), forCellWithReuseIdentifier: kCollecCellID)
 
-        //1.添加刷新
-        collectionVIew.mj_header = MJRefreshNormalHeader(refreshingTarget: self, refreshingAction: #selector(collectionHeaderRefresh))
-        collectionVIew.mj_footer = MJRefreshAutoNormalFooter(refreshingTarget: self, refreshingAction: #selector(collectionFooterRefresh))
+        //1.设置代理
+        //1-1. 绑定cell
+        let dataSource = RxCollectionViewSectionedReloadDataSource<AnchorSection>()
+        dataSource.configureCell = { ds, collectionView, indexPath, item in
+            let cell = collectionView.dequeueReusableCell(withReuseIdentifier: kCollecCellID, for: indexPath) as! RxCollectionViewCell
+            cell.anchorModel = item
+            return cell
+        }
+        
+        //2. 初始化请求
+        let vmInput = AnchorViewModel.JunInput(category: .getNewList)
+        let vmOutput = anchorVM.transform(input: vmInput)
+        
+        //3. 添加刷新
+        collectionVIew.mj_header = MJRefreshNormalHeader(refreshingBlock: {
+            vmOutput.requestCommond.onNext(true)
+        })
         collectionVIew.mj_header.beginRefreshing()
 
-        //2.给collectionView绑定数据
-        anchorVM.heroVariable.asDriver().drive(collectionVIew.rx.items(cellIdentifier: kCollecCellID, cellType: RxCollectionViewCell.self)) { (_, anchor, cell) in
-            cell.anchorModel = anchor
-        }.addDisposableTo(bag)
+        collectionVIew.mj_footer = MJRefreshAutoNormalFooter(refreshingBlock: {
+            vmOutput.requestCommond.onNext(false)
+        })
+        
+        //4. 给collectionView绑定数据
+        vmOutput.sections.asDriver().drive(collectionVIew.rx.items(dataSource: dataSource)).addDisposableTo(bag)
+        
+        //5. 设置刷新状态
+        vmOutput.refreshStatus.asObservable().subscribe(onNext: { (status) in
+            switch status {
+            case .beingHeaderRefresh:
+                self.collectionVIew.mj_header.beginRefreshing()
+            case .endHeaderRefresh:
+                self.collectionVIew.mj_header.endRefreshing()
+            case .beingFooterRefresh:
+                self.collectionVIew.mj_footer.beginRefreshing()
+            case .endFooterRefresh:
+                self.collectionVIew.mj_footer.endRefreshing()
+            case .noMoreData:
+                self.collectionVIew.mj_footer.endRefreshingWithNoMoreData()
+            default:
+                break
+            }
+        }).addDisposableTo(bag)
+        
 
-        // 3.监听collectionView的点击
+        
+        // 6.监听collectionView的点击
         collectionVIew.rx.modelSelected(AnchorModel.self).subscribe(onNext: { (model) in
             print(model.name)
         }).addDisposableTo(bag)
     }
 
 
-    //下拉刷新
-    @objc fileprivate func collectionHeaderRefresh(){
-        
-    }
-    
-    //上拉加载
-    @objc fileprivate func collectionFooterRefresh(){
-        
-    }
 
 }

RxSwift-Table-Collection1/RxSwift-Table-Collection/Tools/ReponseObjectMapper.swift

@@ -7,27 +7,43 @@
 //
 
 import UIKit
+import ObjectMapper
+import RxDataSources
 
-class AnchorModel: NSObject {
+class AnchorModel: Mappable {
 
-    var roomid : Int = 0
-    var name : String = ""
-    var pic51 : String = ""
-    var pic74 : String = ""
-    var live : Int = 0 
-    var push : Int = 0 
-    var focus : Int = 0 
+    var name = ""
+    var pic51 = ""
+    var pic74 = ""
+    var live = 0
+    var push = 0
+    var focus = 0
 
-    var isEvenIndex : Bool = false
+    required init?(map: Map) {
+        
+    }
+    
+    func mapping(map: Map) {
+        name  <- map["name"]
+        pic51 <- map["pic51"]
+        pic74 <- map["pic74"]
+        live  <- map["live"]
+        push  <- map["push"]
+        focus <- map["focus"]
+    }
+}
+
 
+//MARK: SectionModel
+struct AnchorSection {
+    var items: [Item]
 
-    init(dic : [String : Any]) {
-        super.init()
-        
-        name = dic["name"] as? String ?? ""
-        pic51 = dic["pic51"] as? String ?? ""
-        pic74 = dic["pic74"] as? String ?? ""
-        focus = dic["focus"] as? Int ?? 0
+}
 
+extension AnchorSection: SectionModelType {
+    typealias Item = AnchorModel
+    init(original: AnchorSection, items: [AnchorSection.Item]) {
+        self = original
+        self.items = items
     }
 }