iOS 使用Moya网络请求的实现方法

//
// NetAPIManager.swift
// NN110
//
// Created by 陈亦海 on 2017/5/12.
// Copyright © 2017年 陈亦海. All rights reserved.
//

import Foundation
import Moya


enum NetAPIManager {
 case Show
 case upload(bodyData: Data)
 case download
 case request(isTouch: Bool, body: Dictionary<String, Any>? ,isShow: Bool)
}


extension NetAPIManager: TargetType {
 var baseURL: URL {//服务器地址
  
  switch self {
  case .request( _, _, _):
   return URL(string: "https://www.pmphmall.com")!
  default:
   return URL(string: "https://httpbin.org")!
  }
  
  
 }
 
 var path: String {//具体某个方法的路径
  switch self {
  case .Show:
   return ""
  case .upload(_):
   return ""
  case .request(_, _, _):
   return "/app/json.do"
  case .download:
   return ""
  }
 }
 
 var method: Moya.Method {//请求的方法 get或者post之类的
  switch self {
  case .Show:
   return .get
  case .request(_, _, _):
   return .post
  default:
   return .post
  }
 }
 
 var parameters: [String: Any]? {//请求的get post给服务器的参数
  switch self {
  case .Show:
   return nil
  case .request(_, _, _):
   return ["msg":"H4sIAAAAAAAAA11SSZJFIQi7EqPAEgTvf6TP62W7sMoSQhKSWDrs6ZUKVWogLwYV7RjHFBZJlNlzloN6LVqID4a+puxqRdUKVNLwE1TRcZIC/fjF2rPotuXmb84r1gMXbiASZIZbhQdKEewJlz41znDkujCHuQU3dU7G4/PmVRnwArMLXukBv0J23XVahNO3VX35wlgce6TLUzzgPQJFuHngAczl6VhaNXpmRLxJBlMml6gdLWiXxTdO7I+iEyC7XuTirCQXOk4dotgArgkH/InxVjfNTnE/uY46++hyAiLFuFL4cv1Z8WH5DgB2GnvFXMh5gm53Tr13vqqrEYtcdXfkNsMwKB+9sAQ77grNJmquFWOhfXA/DELlMB0KKFtHOc/ronj1ml+Z7qas82L3VWiCVQ+HEitjTVzoFw8RisFN/jJxBY4awvq427McXqnyrfCsl7oeEU6wYgW9yJtj1lOkx0ELL5Fw4z071NaVzRA9ebxWXkFyothgbB445cpRmTC+//F73r1kOyQ3lTpec12XNDR00nnq5/YmJItW3+w1z27lSOLqgVctrxG4xdL9WVPdkH1tkiZ/pUKBGhADAAA="]
  default:
   return nil
  
  }
 }
 
 var sampleData: Data { //编码转义
  return "{}".data(using: String.Encoding.utf8)!
 }
 
 var task: Task { //一个请求任务事件
  
  switch self {

  
  case let .upload(data):
  return .upload(.multipart([MultipartFormData(provider: .data(data), name: "file", fileName: "gif.gif", mimeType: "image/gif")]))
   
  default:
   return .request

  }

  }
 
 var parameterEncoding: ParameterEncoding {//编码的格式
  switch self {
  case .request(_, _, _):
   return URLEncoding.default
  default:
   return URLEncoding.default
  }
  
 }
 //以下两个参数是我自己写，用来控制网络加载的时候是否允许操作，跟是否要显示加载提示，这两个参数在自定义插件的时候会用到
 var touch: Bool { //是否可以操作
  
  switch self {
  case .request(let isTouch, _, _):
   return isTouch
  default:
   return false
  }
  
 }
 
 var show: Bool { //是否显示转圈提示
  
  switch self {
  case .request( _, _,let isShow):
   return isShow
  default:
   return false
  }
  
 }
 
 
}

// MARK: - 设置请求头部信息
let myEndpointClosure = { (target: NetAPIManager) -> Endpoint<NetAPIManager> in
 
 
 let url = target.baseURL.appendingPathComponent(target.path).absoluteString
 let endpoint = Endpoint<NetAPIManager>(
  url: url,
  sampleResponseClosure: { .networkResponse(200, target.sampleData) },
  method: target.method,
  parameters: target.parameters,
  parameterEncoding: target.parameterEncoding
 )

 //在这里设置你的HTTP头部信息
 return endpoint.adding(newHTTPHeaderFields: [
  "Content-Type" : "application/x-www-form-urlencoded",
  "ECP-COOKIE" : ""
  ])
 
}

// MARK: - 设置请求超时时间
let requestClosure = { (endpoint: Endpoint<NetAPIManager>, done: @escaping MoyaProvider<NetAPIManager>.RequestResultClosure) in
 
 guard var request = endpoint.urlRequest else { return }
 
 request.timeoutInterval = 30 //设置请求超时时间
 done(.success(request))
}

//
// MyNetworkActivityPlugin.swift
// NN110
//
// Created by 陈亦海 on 2017/5/10.
// Copyright © 2017年 CocoaPods. All rights reserved.
//

import Foundation
import Result
import Moya


/// Network activity change notification type.
public enum MyNetworkActivityChangeType {
 case began, ended
}

/// Notify a request's network activity changes (request begins or ends).
public final class MyNetworkActivityPlugin: PluginType {
 
 
 
 public typealias MyNetworkActivityClosure = (_ change: MyNetworkActivityChangeType, _ target: TargetType) -> Void
 let myNetworkActivityClosure: MyNetworkActivityClosure
 
 public init(newNetworkActivityClosure: @escaping MyNetworkActivityClosure) {
  self.myNetworkActivityClosure = newNetworkActivityClosure
 }
 
 // MARK: Plugin
 
 /// Called by the provider as soon as the request is about to start
 public func willSend(_ request: RequestType, target: TargetType) {
  myNetworkActivityClosure(.began,target)
 }
 
 /// Called by the provider as soon as a response arrives, even if the request is cancelled.
 public func didReceive(_ result: Result<Moya.Response, MoyaError>, target: TargetType) {
  myNetworkActivityClosure(.ended,target)
 }
}

// MARK: - 自定义的网络提示请求插件
let myNetworkPlugin = MyNetworkActivityPlugin { (state,target) in
 if state == .began {
  //  SwiftSpinner.show("Connecting...")
  
  let api = target as! NetAPIManager
  if api.show {
   print("我可以在这里写加载提示")
  }
  
  if !api.touch {
   print("我可以在这里写禁止用户操作，等待请求结束")
  }

  print("我开始请求(api.touch)")
  
  UIApplication.shared.isNetworkActivityIndicatorVisible = true
 } else {
  //  SwiftSpinner.show("request finish...")
  //  SwiftSpinner.hide()
  print("我结束请求")
  UIApplication.shared.isNetworkActivityIndicatorVisible = false
  
 }
}

let MyAPIProvider = MoyaProvider<NetAPIManager>(endpointClosure: myEndpointClosure,requestClosure: requestClosure, plugins: [NetworkLoggerPlugin(verbose: true, responseDataFormatter: JSONResponseDataFormatter),myNetworkPlugin])

// MARK: -创建一个Moya请求
func sendRequest(_ postDict: Dictionary<String, Any>? = nil,
     success:@escaping (Dictionary<String, Any>)->(),
     failure:@escaping (MoyaError)->()) -> Cancellable? {
 
 let request = MyAPIProvider.request(.Show) { result in 
  switch result {
  case let .success(moyaResponse):
   
   
   do {
    let any = try moyaResponse.mapJSON()
    let data = moyaResponse.data
    let statusCode = moyaResponse.statusCode
    MyLog("(data) --- (statusCode) ----- (any)")
    
    success(["":""])
    

   } catch {
    
   }
   
   
   
  case let .failure(error):
   
   print(error)
   failure(error)
  }
 }
 
 return request
}

// MARK: -取消所有请求
func cancelAllRequest() {
// MyAPIProvider.manager.session.invalidateAndCancel() //取消所有请求
 MyAPIProvider.manager.session.getTasksWithCompletionHandler { dataTasks, uploadTasks, downloadTasks in
  dataTasks.forEach { $0.cancel() }
  uploadTasks.forEach { $0.cancel() }
  downloadTasks.forEach { $0.cancel() }
 }
 
 //let sessionManager = Alamofire.SessionManager.default
 //sessionManager.session.getTasksWithCompletionHandler { dataTasks, uploadTasks, downloadTasks in
 // dataTasks.forEach { $0.cancel() }
 // uploadTasks.forEach { $0.cancel() }
 // downloadTasks.forEach { $0.cancel() }
 //}

}