Proyectos de Subversion Iphone Microlearning

//

//  SyncAdapter.swift

//  twogetskills

//

//  Created by Efrain Yanez Recanatini on 2/24/22.

//

import Foundation

import Foundation

import Alamofire

import SwiftyJSON

class SyncAdapter

{

    var syncDao = SyncDao()

    var inProgress = false;

    @objc func updateTimer() {

        //print("updateTimer")

        if inProgress   {

            return

        }

        inProgress = true

        let myQue = DispatchQueue(label: "syncQue")

        myQue.async {

            self.sync{ success in

                self.inProgress = false;

            }

        }

    }

    func sync(completionHandler : @escaping (_ success : Bool) -> Void) {

        let recordsSync = self.syncDao.selectBatch()

        if recordsSync.count > 0 {

            var availableForOtherOperation = true;

            for recordSync in recordsSync

            {

                print(recordSync)

                if recordSync.type == Constants.SYNC_ADAPTER_TYPE_DEVICE {

                    availableForOtherOperation = false

                    registerDevice(record: recordSync)

                }

                else if availableForOtherOperation && recordSync.type == Constants.SYNC_ADAPTER_TYPE_FCM {

                    availableForOtherOperation = false

                    registerFcm(record: recordSync)

                }

                else if availableForOtherOperation && recordSync.type == Constants.SYNC_ADAPTER_TYPE_SYNC {

                    availableForOtherOperation = false

                    sendSync(record: recordSync)

                }

                else if recordSync.data.isEmpty {

                    syncDao.remove(id: recordSync.id)

                }

            }

        }

        completionHandler(true)

    }

    func sendSync(record: SyncModel)

    {

        let preference = Preference.sharedInstance

        let parameters = [

            Constants.POST_SYNC_FIELD_DEVICE_UUID: "\(preference.deviceUuid)",

            Constants.POST_SYNC_FIELD_DATA: "\(record.data)",

            Constants.POST_SYNC_FIELD_SYNC_ID: "\(record.id)"

        ]

        let headers: HTTPHeaders = [

            .accept(Constants.HTTP_HEADER_ACCEPT)

        ]

        AF.request(Config.URL_SYNC, method: .post, parameters: parameters, encoding: URLEncoding.default, headers: headers).responseJSON {response in

            print("Send Sync  ")

            switch response.result {

                case .success:

                    let result = try? JSON(data: response.data!)

                    if result?["success"] ?? "" != false{

                        let sync_id = Int(result?["data"]["sync_id"].stringValue ?? "0") ?? 0

                        if sync_id > 0 {

                            self.syncDao.remove(id: sync_id)

                        }

                    }

                break

                case .failure:

                    print("JSON = \(String(describing: Error.self))")

                break

            }

        }

    }

    func registerFcm(record: SyncModel) {

        let preference = Preference.sharedInstance

        let deviceUuid = preference.deviceUuid

        let parameters = [

            Constants.POST_FCM_FIELD_APPLICATION_ID: "\(Constants.GLOBAL_APPLICATION_ID)",

            Constants.POST_FCM_FIELD_DEVICE_UUID: "\(deviceUuid)",

            Constants.POST_FCM_FIELD_TOKEN: "\(record.data)",

            Constants.POST_FCM_FIELD_SYNC_ID: "\(record.id)"

        ]

        let headers: HTTPHeaders = [

            .accept(Constants.HTTP_HEADER_ACCEPT)

        ]

        AF.request(Config.URL_FCM, method: .post, parameters: parameters, encoding: URLEncoding.default, headers: headers).responseJSON{response in

            print("Send FCM")

            switch response.result {

                case .success:

                    let result = try? JSON(data: response.data!)

                    let sync_id = Int(result?["data"]["sync_id"].stringValue ?? "0") ?? 0

                    if sync_id > 0 {

                        self.syncDao.remove(id: sync_id)

                    }

                    break

                case .failure:

                    print("JSON = \(String(describing: Error.self))")

                    break

            }

        }

    }

    func registerDevice(record: SyncModel)

    {

        let version = UIDevice.current.systemVersion

        let model = UIDevice.current.localizedModel

        let parameters = [

            Constants.POST_DEVICE_FIELD_APPLICATION_ID: "1",

            Constants.POST_DEVICE_FIELD_DEVICE_UUID: "\(record.data)",

            Constants.POST_DEVICE_FIELD_MANUFACTURER: "Apple",

            Constants.POST_DEVICE_FIELD_BRAND: "Apple",

            Constants.POST_DEVICE_FIELD_VERSION: "\(version)",

            Constants.POST_DEVICE_FIELD_MODEL: "\(model)",

            Constants.POST_DEVICE_FIELD_PLATFORM: "Iphone",

            Constants.POST_DEVICE_FIELD_SYNC_ID: "\(record.id)"

        ]

        let headers: HTTPHeaders = [

            .accept(Constants.HTTP_HEADER_ACCEPT)

        ]

        print("URL DEVICE : \(Config.URL_DEVICE) ")

        AF.request(Config.URL_DEVICE, method: .post, parameters: parameters, encoding: URLEncoding.default, headers: headers).responseJSON {response in

            print("Send Device: ")

            switch response.result {

                case .success:

                    let result = try? JSON(data: response.data!)

                    if result?["success"] ?? "" != false {

                        let aes = result?["data"]["aes"].stringValue ?? ""

                        let password = result?["data"]["password"].stringValue ?? ""

                        if !aes.isEmpty && !password.isEmpty {

                            let preference = Preference.sharedInstance

                            preference.aes = aes

                            preference.password = password

                            preference.save()

                        }

                        let sync_id = Int(result?["data"]["sync_id"].stringValue ?? "0") ?? 0

                        if sync_id > 0 {

                            self.syncDao.remove(id: sync_id)

                        }

                    }

                break

                case .failure:

                    print("JSON = \(String(describing: Error.self))")

                break

            }

        }

    }

}