O2OA/o2ios/O2Platform/App/O2MainController.swift

//
//  O2MainController.swift
//  O2Platform
//
//  Created by FancyLou on 2019/1/25.
//  Copyright © 2019 zoneland. All rights reserved.
//

import UIKit
import CocoaLumberjack
import O2OA_Auth_SDK
import Starscream
import AudioToolbox

class O2MainController: UITabBarController, UITabBarControllerDelegate {

    static var tabBarVC: O2MainController!

    static func genernateVC() -> O2MainController {
//        guard let vc = tabBarVC else {
//            tabBarVC = O2MainController()
//            return tabBarVC
//        }
//        return vc
        return O2MainController()
    }

    private var currentIndex: Int = 0
    // demo服务器弹出公告
    private var demoAlertView = O2DemoAlertView()
    private let viewModel: OOLoginViewModel = {
        return OOLoginViewModel()
    }()
    //获取消息数量
    private lazy var imViewModel: IMViewModel = {
        return IMViewModel()
    }()


    override func viewDidLoad() {
        super.viewDidLoad()
        if UIDevice.deviceModelReadable() != "Simulator" {
            self.checkAppVersion()
        }
        //
        self.tabBar.tintColor = O2ThemeManager.color(for: "Base.base_color")!
        self.delegate = self
        _initControllers()
        selectedIndex = 2
        currentIndex = 2
//        _loginIM()
        if O2IsConnect2Collect == false {
            //处理内部直连的时候推送的设备绑定
            O2JPushManager.shared.o2JPushBind()
        }
        //连接websocket
        self._startWebsocket()
        //读取消息
        self.getConversationList()
    }

    deinit {
        //关闭websocket
        self._stopWebsocket()
    }

    override func viewDidAppear(_ animated: Bool) {
        // 判断是否 第一次安装 是否是连接的demo服务器
        if let unit = O2AuthSDK.shared.bindUnit() {
            if "demo.o2oa.net" == unit.centerHost || "demo.o2oa.io" == unit.centerHost || "demo.o2server.io" == unit.centerHost || "sample.o2oa.net" == unit.centerHost {
                let tag = AppConfigSettings.shared.demoAlertTag
                if !tag {
                    demoAlertView.showFallDown()
                    AppConfigSettings.shared.demoAlertTag = true
                }
            }
        }
    }

    //MARK: -- delegate
    func tabBarController(_ tabBarController: UITabBarController, didSelect viewController: UIViewController) {
        self.currentIndex = tabBarController.selectedIndex
    }

    private func _initControllers() {
        //消息
//        let conversationVC = JCConversationListViewController()
        let conversationVC = IMConversationListViewController()
        conversationVC.title = "消息"
        let messages = ZLNavigationController(rootViewController: conversationVC)
        messages.tabBarItem = UITabBarItem(title: "消息", image: UIImage(named: "icon_news_nor"), selectedImage: O2ThemeManager.image(for: "Icon.icon_news_pre"))

        //通讯录
        let addressVC = OOTabBarHelper.getVC(storyboardName: "contacts", vcName: nil)
        let address = ZLNavigationController(rootViewController: addressVC)
        address.tabBarItem = UITabBarItem(title: "通讯录", image: UIImage(named: "icon_address_g"), selectedImage: O2ThemeManager.image(for: "Icon.icon_address_list_pro"))

        // main
        let mainVC = mainController()
        mainVC.tabBarItem = UITabBarItem(title: nil, image: UIImage(named: "icon_zhuye_nor"), selectedImage: O2ThemeManager.image(for: "Icon.icon_zhuye_pre"))
        mainVC.tabBarItem.imageInsets = UIEdgeInsets(top: 6, left: 0, bottom: -6, right: 0)
        let blurImage = OOCustomImageManager.default.loadImage(.index_bottom_menu_logo_blur)
        let newBlurImage = blurImage?.withRenderingMode(.alwaysOriginal)
        mainVC.tabBarItem.image = newBlurImage
        let focusImage = OOCustomImageManager.default.loadImage(.index_bottom_menu_logo_focus)
        let newFocusImage = focusImage?.withRenderingMode(.alwaysOriginal)
        mainVC.tabBarItem.selectedImage = newFocusImage

        //应用
        let appsVC = OOTabBarHelper.getVC(storyboardName: "apps", vcName: nil)
        let apps = ZLNavigationController(rootViewController: appsVC)
        apps.tabBarItem = UITabBarItem(title: "应用", image: UIImage(named: "icon_yingyong"), selectedImage: O2ThemeManager.image(for: "Icon.icon_yingyong_pro"))

        //设置
        let settingsVC = OOTabBarHelper.getVC(storyboardName: "setting", vcName: nil)
        let settings = ZLNavigationController(rootViewController: settingsVC)
        settings.tabBarItem = UITabBarItem(title: "设置", image: UIImage(named: "setting_normal"), selectedImage: O2ThemeManager.image(for: "Icon.setting_selected"))

        self.viewControllers = [messages, address, mainVC, apps, settings]

    }

    private func mainController() -> UIViewController {
        let appid = O2AuthSDK.shared.customStyle()?.indexPortal
        let indexType = O2AuthSDK.shared.customStyle()?.indexType ?? "default"
        if indexType == "portal" {
            let app = DBManager.shared.queryData(appid!)
            let destVC = OOTabBarHelper.getVC(storyboardName: "apps", vcName: "OOMainWebVC")
            if let mail = destVC as? MailViewController {
                mail.app = app
                mail.isIndexShow = true
                let nav = ZLNavigationController(rootViewController: mail)
                return nav
            } else {
                let nav = ZLNavigationController(rootViewController: destVC)
                return nav
            }
        } else {
            let destVC = OOTabBarHelper.getVC(storyboardName: "task", vcName: nil)
            let nav = ZLNavigationController(rootViewController: destVC)
            return nav
        }
    }

    
    // MARK: - IM message
    func getConversationList() {
        imViewModel.myConversationList().then { (list) in
            var n = 0
            if !list.isEmpty {
                for item in list {
                    if let number = item.unreadNumber {
                        n += number
                    }
                }
            }
            DispatchQueue.main.async {
                DDLogDebug("消息数量: \(n)")
                if n > 0 && n < 100 {
                    self.showRedPoint(number: "\(n)")
                } else if n >= 100 {
                    self.showRedPoint(number: "99..")
                }
            }
        }
    }

    private func showRedPoint(number: String) {
        self.viewControllers?.forEach({ (vc) in
            if let zl = vc as? ZLNavigationController, zl.tabBarItem?.title == "消息" {
                zl.tabBarItem.badgeValue = number
            }
        })
    }
    //消息模块未读消息数量加1
    private func addUnreadNumber() {
        self.viewControllers?.forEach({ (vc) in
            if let zl = vc as? ZLNavigationController, zl.tabBarItem?.title == "消息" {
                if let badge = zl.tabBarItem.badgeValue {
                    if badge != "99.." {
                        if let n = Int(string: badge) {
                            let number = n + 1
                            if number > 0 && number < 100 {
                                self.showRedPoint(number: "\(number)")
                            } else if number >= 100 {
                                self.showRedPoint(number: "99..")
                            }
                        }
                    }
                }else {
                    self.showRedPoint(number: "1")
                }
            }
        })
    }

//    private func _loginIM() {
//        viewModel.registerIM().then { (result) in
//            self.viewModel.loginIM().then({ (result) in
//                Log.debug(message: "IM登陆完成")
//            })
//        }.catch { (imError) in
//            let error = imError as! OOLoginError
//            switch error {
//            case .imRegisterFail(let myErr):
//                Log.debug(message: myErr.errorDescription!)
//                self.viewModel.loginIM().then({ (result) in
//                    Log.debug(message: "IM登陆完成")
//                }).catch({ (loginError) in
//                    Log.error(message: "im Login Error \(loginError)")
//                })
//                break
//            default:
//                break
//            }
//        }
//    }

    
    // MARK: - app update 
    private func checkAppVersion() {
        O2VersionManager.shared.checkAppUpdate { (info, error) in
            if let iosInfo = info {
                DDLogDebug(iosInfo.toJSONString() ?? "")
                let alertController = UIAlertController(title: "版本更新", message: "更新内容：\(iosInfo.content ?? "")", preferredStyle: .alert)
                let okAction = UIAlertAction(title: "确定", style: .default, handler: { ok in
                    O2VersionManager.shared.updateAppVersion(info?.downloadUrl)
                })
                let cancelAction = UIAlertAction(title: "取消", style: .cancel, handler: { c in
                    //
                })
                alertController.addAction(cancelAction)
                alertController.addAction(okAction)
                UIApplication.shared.keyWindow?.rootViewController?.present(alertController, animated: true, completion: nil)
            } else {
                DDLogInfo("没有版本更新：\(error ?? "")")
            }
        }
    }



    // MARK: - websocket
    private var timer: Timer?
    private var isWsOpen = false

    private func _startWebsocket() {
        DDLogDebug("启动websocket连接。。。。。。")
        let url = AppDelegate.o2Collect.generateWebsocketURL()
        DDLogDebug("这个是wsurl ：\(url)")
        O2WebsocketManager.instance.startConnect(wsUrl: url, delegate: self)
    }

    private func _stopWebsocket() {
        DDLogDebug("关闭websocket连接。。。。。。")
        self.stopTiming()
        O2WebsocketManager.instance.closeConnect()
    }

    private func startTiming() {
        DDLogDebug("开启定时器 。。。。。。")
        if timer != nil {
            timer?.invalidate()
            timer = nil
        }
        timer = Timer.scheduledTimer(timeInterval: 30, target: self, selector: #selector(sendHeartbeatMsg), userInfo: nil, repeats: true)
        timer?.fire()
    }
    private func stopTiming() {
        DDLogDebug("关闭定时器 。。。。。。")
        if timer != nil {
            timer?.invalidate()
            timer = nil
        }
    }
    //发送心跳
    @objc private func sendHeartbeatMsg() {
        if isWsOpen {
            O2WebsocketManager.instance.send(msg: o2_im_ws_heartbeat)
        } else { //重新启动
            _startWebsocket()
        }
    }

}

extension O2MainController: WebSocketDelegate {


    func didReceive(event: WebSocketEvent, client: WebSocket) {
        switch event {
        case .text(let text):
            if text != o2_im_ws_heartbeat { //忽略心跳消息
                DDLogDebug("接收的ws消息：\(text)")
                //判断type im消息就发送通知
                do {
                    if let dicArr = try JSONSerialization.jsonObject(with: String(text).data(using: .utf8)!, options: .allowFragments) as? [String: AnyObject] {
                        if let type = dicArr["type"] as? String, type == "im_create" {
                            if let messageInfo = WsMessage.deserialize(from: text) {
                                DDLogDebug("接收到im消息 发送通知。。")
                                NotificationCenter.post(customeNotification: OONotification.websocket, object: messageInfo.body)
                            }
                            self.addUnreadNumber()
                            AudioServicesPlaySystemSound(kSystemSoundID_Vibrate)
                        }
                    }
                } catch { }
            }
            break
        case .connected(let headers):
            DDLogDebug("websocket is connected: \(headers)")
            isWsOpen = true
            self.startTiming()
            break
        case .disconnected(let reason, let code):
            DDLogDebug("websocket is disconnected: \(reason) with code: \(code)")
            isWsOpen = false
            break
        case .binary(let data):
            DDLogDebug("Received binary data: \(data.count)")
            break
        case .ping(_):
            break
        case .pong(_):
            break
        case .viablityChanged(_):
            DDLogDebug("websocket viablityChanged")
            break
        case .reconnectSuggested(_):
            DDLogDebug("websocket reconnectSuggested")
            break
        case .cancelled:
            DDLogDebug("websocket is canceled")
            isWsOpen = false
            break
        case .error(let error):
            DDLogError("websocket is error, \(String(describing: error?.localizedDescription))")
            isWsOpen = false
            break
        }
    }


}