//
//  GroupChatVC.swift
//  QuickLocation
//
//  Created by 八条 on 2026/6/4.
//

import UIKit
import RxSwift
import RxCocoa
import RxDataSources
import OpenIMSDK
import AVFoundation
import AudioToolbox
import HXPHPicker
import IQKeyboardManagerSwift
import MJRefresh

final class GroupChatVC: BaseViewController {

    override var isNavigationBarHidden: Bool { true }

    fileprivate var rootView: GroupChatView!
    private let viewModel = GroupChatViewModel()
    private var msgListener: MessageListenerProxy?
    /// mention 列表：首行 @所有人 + 成员
    private var mentionRows: [(userId: String?, nickname: String)] = []
    private var isMentionPickerVisible = false
    /// 加载更早历史前记录，用于保持阅读位置
    private var pendingOffsetRestore: (oldHeight: CGFloat, oldOffset: CGFloat)?

    // MARK: - Init
    init(groupId: String) {
        viewModel.groupId = groupId
        super.init(nibName: nil, bundle: nil)
    }

    required init?(coder: NSCoder) {
        fatalError("init(coder:) has not been implemented")
    }

    override func loadView() {
        rootView = GroupChatView(frame: UIScreen.main.bounds)
        view = rootView
    }

    override func viewDidLoad() {
        super.viewDidLoad()
        fd_interactivePopDisabled = true
        bindViewModel()
        reactiveAction()
        setupMessageListener()
        setupVoiceRecording()
        setupPanelDismiss()
        setupChatLongPress()
        setupMentionInput()
        setupHistoryRefreshHeader()

        // 并行加载：业务接口 + IM SDK 互不依赖，同时发起
        requestGroupInfoByKey()
        GroupIMService.shared.ensureLogin { [weak self] success in
            guard let self = self, success else { return }
            self.viewModel.loadMessages()
        }

        // 处理系统配置
        guard let config = AppContextManager.shared.systemConfig else { return }
        rootView.chatWarningView.isHidden = config.chatWarning.isEmpty
        rootView.chatWarningLab.text = config.chatWarning
    }

    override func viewWillAppear(_ animated: Bool) {
        super.viewWillAppear(animated)
        setupKeyboard()
        IQKeyboardManager.shared.isEnabled = false
        IQKeyboardManager.shared.resignOnTouchOutside = false
        
        // 非圈主 会员权益拦截
        guard viewModel.groupId.contains(AppContextManager.shared.userId) == false else { return }
        rootView.disableIMView.isHidden = AppContextManager.shared.vip > 1
    }

    override func viewWillDisappear(_ animated: Bool) {
        super.viewWillDisappear(animated)
        VoicePlayerManager.shared.stop()
        IQKeyboardManager.shared.isEnabled = true
        IQKeyboardManager.shared.resignOnTouchOutside = true
    }
    
    override func viewDidDisappear(_ animated: Bool) {
        super.viewDidDisappear(animated)
        NotificationCenter.default.removeObserver(self)
    }

    // MARK: - Keyboard
    private func setupKeyboard() {
        // 键盘升起
        NotificationCenter.default.rx.notification(UIResponder.keyboardWillShowNotification)
            .subscribe(onNext: { [weak self] noti in
                guard let self = self,
                      // 只在 VC 本身可见时响应，避免导航栈下层 VC 被全局通知唤醒
                      self.isViewLoaded && self.view.window != nil,
                      let userInfo = noti.userInfo,
                      let frame = userInfo[UIResponder.keyboardFrameEndUserInfoKey] as? CGRect
                else { return }
                let height = frame.height
                let duration = (userInfo[UIResponder.keyboardAnimationDurationUserInfoKey] as? Double) ?? 0.25
                // 收起表情/语音面板
                self.rootView.dismissAllPanels(excludeTextField: true)
                UIView.animate(withDuration: duration) {
                    self.rootView.bottomBar.layoutChain.bottom(height + 20)
                }
                self.scrollToBottom()
            })
            .disposed(by: disposeBag)
    }

    private func setupPanelDismiss() {
        // 用户开始拖拽 tableview 时收起面板
        rootView.tableView.panGestureRecognizer.rx.event
            .filter { $0.state == .began }
            .subscribe(onNext: { [weak self] _ in
                self?.rootView.dismissAllPanels()
            })
            .disposed(by: disposeBag)

        // 点击 cell 收起面板
        rootView.tableView.rx.itemSelected
            .subscribe(onNext: { [weak self] _ in
                self?.rootView.dismissAllPanels()
            })
            .disposed(by: disposeBag)
    }

    // MARK: - Bindings
    private func bindViewModel() {
        rootView.tableView.rx.setDelegate(self)
            .disposed(by: disposeBag)

        viewModel.output.messages
            .skip(1)
            .map { [ChatSectionModel(model: "", items: $0)] }
            .observe(on: MainScheduler.asyncInstance)
            .bind(to: rootView.tableView.rx.items(dataSource: dataSource))
            .disposed(by: disposeBag)

        viewModel.output.messages
            .skip(1)
            .observe(on: MainScheduler.asyncInstance)
            .subscribe(onNext: { [weak self] _ in
                guard let self = self else { return }
                if self.viewModel.suppressAutoScroll {
                    self.viewModel.suppressAutoScroll = false
                    self.restoreOffsetAfterPrependIfNeeded()
                    return
                }
                self.rootView.tableView.mj_header?.isHidden = !self.viewModel.hasMoreHistory
                self.scrollToBottom()
            })
            .disposed(by: disposeBag)

        viewModel.output.pendingQuoteSummary
            .observe(on: MainScheduler.instance)
            .subscribe(onNext: { [weak self] summary in
                guard let self = self else { return }
                if let summary {
                    self.rootView.setQuoteBarVisible(true, summary: summary)
                    self.bringInputOverlaysToFront()
                } else {
                    self.rootView.setQuoteBarVisible(false)
                }
            })
            .disposed(by: disposeBag)

        rootView.quoteBarCloseBtn.rx.tap
            .subscribe(onNext: { [weak self] in
                self?.viewModel.clearPendingQuote()
            })
            .disposed(by: disposeBag)

        let emojiItems = UIView.emojiFileNames.map { $0 }
        Observable.just([SectionModel(model: "", items: emojiItems)])
            .bind(to: rootView.emojiCollectionView.rx.items(dataSource: emojiDataSource))
            .disposed(by: disposeBag)
    }

    private func bringInputOverlaysToFront() {
        rootView.bringSubviewToFront(rootView.mentionPickerView)
        rootView.bringSubviewToFront(rootView.quoteBar)
        rootView.bringSubviewToFront(rootView.bottomBar)
        rootView.bringSubviewToFront(rootView.disableIMView)
    }

    // MARK: - 顶部加载更早历史
    private func setupHistoryRefreshHeader() {
        let header = MJRefreshNormalHeader { [weak self] in
            self?.loadOlderHistoryFromHeader()
        }
        header.addFeedbackGenerator()
        header.lastUpdatedTimeLabel?.isHidden = true
        header.setTitle("下拉加载更早消息", for: .idle)
        header.setTitle("松开加载", for: .pulling)
        header.setTitle("加载中...", for: .refreshing)
        rootView.tableView.mj_header = header
    }

    private func loadOlderHistoryFromHeader() {
        guard viewModel.hasMoreHistory else {
            rootView.tableView.mj_header?.endRefreshing()
            rootView.tableView.mj_header?.isHidden = true
            return
        }
        let tableView = rootView.tableView
        pendingOffsetRestore = (tableView.contentSize.height, tableView.contentOffset.y)
        viewModel.loadOlderHistory { [weak self] result in
            guard let self = self else { return }
            self.rootView.tableView.mj_header?.endRefreshing()
            if !result.hasMore {
                self.rootView.tableView.mj_header?.isHidden = true
            }
            // suppressAutoScroll 路径里会 restoreOffset；若未 prepend 也清掉 pending
            if result.prependedCount == 0 {
                self.pendingOffsetRestore = nil
            }
        }
    }

    private func restoreOffsetAfterPrependIfNeeded() {
        guard let pending = pendingOffsetRestore else { return }
        pendingOffsetRestore = nil
        let tableView = rootView.tableView
        tableView.layoutIfNeeded()
        let delta = tableView.contentSize.height - pending.oldHeight
        guard delta > 0 else { return }
        var offset = tableView.contentOffset
        offset.y = max(0, pending.oldOffset + delta)
        tableView.setContentOffset(offset, animated: false)
    }

    private func scrollToBottom() {
        let count = dataSource.sectionModels.first?.items.count ?? 0
        guard count > 0 else { return }
        DispatchQueue.main.async {
            self.rootView.tableView.layoutIfNeeded()
            let indexPath = IndexPath(row: count - 1, section: 0)
            self.rootView.tableView.scrollToRow(at: indexPath, at: .bottom, animated: false)
        }
    }

    private func scrollToMessage(clientMsgID: String) {
        viewModel.ensureMessageVisible(clientMsgID: clientMsgID) { [weak self] found in
            guard let self = self else { return }
            guard found, let indexPath = self.viewModel.indexPath(forClientMsgID: clientMsgID) else {
                DLToast.showError(text: "无法定位到原消息")
                return
            }
            self.rootView.tableView.layoutIfNeeded()
            self.rootView.tableView.scrollToRow(at: indexPath, at: .middle, animated: true)
            DispatchQueue.main.asyncAfter(deadline: .now() + 0.25) {
                if let cell = self.rootView.tableView.cellForRow(at: indexPath) as? TextSendMsgCell {
                    cell.flashHighlight()
                } else if let cell = self.rootView.tableView.cellForRow(at: indexPath) as? TextReceivedMsgCell {
                    cell.flashHighlight()
                } else if let cell = self.rootView.tableView.cellForRow(at: indexPath) {
                    let old = cell.contentView.backgroundColor
                    cell.contentView.backgroundColor = UIColor(hexStr: "#16B3FF").withAlphaComponent(0.12)
                    UIView.animate(withDuration: 0.8, delay: 0.3, options: []) {
                        cell.contentView.backgroundColor = old
                    }
                }
            }
        }
    }

    private lazy var emojiDataSource: RxCollectionViewSectionedReloadDataSource<SectionModel<String, String>> = {
        RxCollectionViewSectionedReloadDataSource<SectionModel<String, String>> { _, collectionView, indexPath, name in
            let cell: EmojiPanelCell = collectionView.dequeueReusableCell(for: indexPath)
            cell.configure(name: name)
            return cell
        }
    }()

    // MARK: - Message Listener
    private func setupMessageListener() {
        msgListener = MessageListenerProxy(
            onMessage: { [weak self] msg in
                guard let self = self, msg.groupID == self.viewModel.groupId else { return }
                self.viewModel.onReceiveMessage(msg)
            },
            onRevoked: { [weak self] info in
                self?.viewModel.onMessageRevoked(info)
            }
        )
        OIMManager.callbacker.addAdvancedMsgListener(listener: msgListener!)
    }

    // MARK: - Long press (quote / revoke / avatar @)
    private func setupChatLongPress() {
        let longPress = UILongPressGestureRecognizer(target: self, action: #selector(handleChatLongPress(_:)))
        longPress.minimumPressDuration = 0.45
        rootView.tableView.addGestureRecognizer(longPress)
    }

    @objc private func handleChatLongPress(_ gesture: UILongPressGestureRecognizer) {
        guard gesture.state == .began else { return }
        let point = gesture.location(in: rootView.tableView)
        guard let indexPath = rootView.tableView.indexPathForRow(at: point),
              let cell = rootView.tableView.cellForRow(at: indexPath) else { return }
        let items = viewModel.currentMessages
        guard indexPath.row < items.count,
              let msg = items[indexPath.row].chatMessage else { return }

        // 长按对方头像 → @
            if !msg.isSelf, let avatar = avatarView(in: cell) {
            let p = gesture.location(in: avatar)
            if avatar.bounds.insetBy(dx: -6, dy: -6).contains(p) {
                insertMention(userId: msg.senderId, nickname: msg.senderName, replaceTriggerAt: false)
                return
            }
        }

        showBubbleActionMenu(for: msg, from: cell)
    }

    private func avatarView(in cell: UITableViewCell) -> UIImageView? {
        if let c = cell as? TextReceivedMsgCell { return c.avatarView }
        if let c = cell as? EmojiReceivedMsgCell { return c.avatarView }
        if let c = cell as? VoiceReceivedMsgCell { return c.avatarView }
        if let c = cell as? ImageReceivedMsgCell { return c.avatarView }
        return nil
    }

    private func menuAnchorView(in cell: UITableViewCell) -> UIView {
        if let c = cell as? TextSendMsgCell { return c.menuAnchorView }
        if let c = cell as? TextReceivedMsgCell { return c.menuAnchorView }
        if let c = cell as? EmojiSendMsgCell { return c.menuAnchorView }
        if let c = cell as? EmojiReceivedMsgCell { return c.menuAnchorView }
        if let c = cell as? VoiceSendMsgCell { return c.menuAnchorView }
        if let c = cell as? VoiceReceivedMsgCell { return c.menuAnchorView }
        if let c = cell as? ImageSendMsgCell { return c.menuAnchorView }
        if let c = cell as? ImageReceivedMsgCell { return c.menuAnchorView }
        return cell.contentView
    }

    private weak var bubbleMenu: ChatBubbleActionMenu?

    private func showBubbleActionMenu(for msg: ChatMessage, from cell: UITableViewCell) {
        bubbleMenu?.dismiss()
        rootView.dismissAllPanels()

        let menu = ChatBubbleActionMenu()
        bubbleMenu = menu
        menu.onQuote = { [weak self] in
            guard let self = self,
                  let oim = self.viewModel.oimMessage(forClientMsgID: msg.id) else {
                DLToast.showError(text: "无法引用该消息")
                return
            }
            self.viewModel.setPendingQuote(oim)
            self.rootView.textField.becomeFirstResponder()
        }
        menu.onRevoke = { [weak self] in
            self?.viewModel.revokeMessage(clientMsgID: msg.id)
        }
        let anchor = menuAnchorView(in: cell)
//        menu.show(in: rootView, anchor: anchor, showRevoke: msg.isSelf)
    }

    // MARK: - Mention
    private func setupMentionInput() {
        rootView.textField.delegate = self
        rootView.mentionTableView.delegate = self
        rootView.mentionTableView.dataSource = self
        rootView.textField.rx.controlEvent(.editingChanged)
            .subscribe(onNext: { [weak self] in
                self?.handleMentionTrigger()
            })
            .disposed(by: disposeBag)
    }

    private func handleMentionTrigger() {
        guard let text = rootView.textField.text,
              let selected = rootView.textField.selectedTextRange else {
            hideMentionPicker()
            return
        }
        let cursor = rootView.textField.offset(from: rootView.textField.beginningOfDocument, to: selected.start)
        let ns = text as NSString
        let prefix = ns.substring(to: min(cursor, ns.length))
        if prefix.hasSuffix("@") {
            showMentionPicker()
        } else if isMentionPickerVisible {
            // 继续输入非空格时保持；遇到空格关闭
            if prefix.last == " " || !prefix.contains("@") {
                hideMentionPicker()
            }
        }
    }

    private func showMentionPicker() {
        mentionRows = [(nil, "所有人")] + viewModel.mentionCandidates().map { ($0.user_id, $0.nick_name) }
        rootView.mentionTableView.reloadData()
        rootView.mentionPickerView.isHidden = false
        isMentionPickerVisible = true
        bringInputOverlaysToFront()
        rootView.layoutIfNeeded()
        let bounds = rootView.mentionPickerView.bounds
        rootView.mentionPickerView.layer.shadowPath = UIBezierPath(roundedRect: bounds, cornerRadius: 12).cgPath
    }

    private func hideMentionPicker() {
        rootView.mentionPickerView.isHidden = true
        isMentionPickerVisible = false
    }

    private func insertMention(userId: String?, nickname: String, replaceTriggerAt: Bool = true) {
        hideMentionPicker()
        let insert: String
        if let userId {
            insert = viewModel.mentionUser(userId: userId, nickname: nickname)
        } else {
            viewModel.setPendingAtAll(true)
            insert = "@所有人 "
        }
        var current = rootView.textField.text ?? ""
        if replaceTriggerAt, let atIdx = current.lastIndex(of: "@") {
            let after = current[current.index(after: atIdx)...]
            if after.isEmpty || !after.contains(where: { $0.isWhitespace }) {
                current = String(current[..<atIdx])
            }
        }
        rootView.textField.text = current + insert
        rootView.textField.becomeFirstResponder()
    }

    // MARK: - Actions
    private func reactiveAction() {
        rootView.backBtn.rx.tap
            .subscribe(onNext: { _ in
                AppRouter.shared.popOrDismiss()
            })
            .disposed(by: disposeBag)

        // 审核
        rootView.reviewBtn.rx.tap.subscribe(onNext: { _ in
            AppRouter.push(Route.reviewMemberList, userInfo: ["groupId": self.viewModel.groupId])
        }).disposed(by: disposeBag)
        
        // 成员列表
        rootView.memberBtn.rx.tap.subscribe(onNext: { _ in
            AppRouter.push(Route.groupMemberList, userInfo: ["groupKey": self.viewModel.groupId])
        }).disposed(by: disposeBag)
        
        // 语音按钮
        rootView.voiceBtn.rx.tap.subscribe(onNext: { [weak self] _ in
            guard let self = self else { return }
            let status = AVCaptureDevice.authorizationStatus(for: .audio)
            switch status {
            case .authorized:
                break
            case .notDetermined:
                AVAudioSession.sharedInstance().requestRecordPermission { granted in
                    guard granted else { return }
                    DispatchQueue.main.async {
                        self.rootView.dismissAllPanels()
                        self.showSpeakPanel()
                    }
                }
                return
            default:
                Permission.openAppSetting(title: "请开启麦克风权限",
                                          message: "请在iPhone的“设置-隐私-麦克风”选项中允许\(kAppName)访问你的麦克风。")
                return
            }
            self.rootView.dismissAllPanels()
            self.showSpeakPanel()
        })
        .disposed(by: disposeBag)
        
        // 键盘按钮
        rootView.voiceRecordView.keyboardBtn.rx.tap
            .subscribe(onNext: { [weak self] _ in
                guard let self = self else { return }
                self.rootView.dismissAllPanels()
                self.rootView.textField.becomeFirstResponder()
            })
            .disposed(by: disposeBag)
        
        // 表情按钮
        rootView.emojiBtn.rx.tap
            .subscribe(onNext: { [weak self] _ in
                guard let self = self else { return }
                self.showEmojiPanel()
            })
            .disposed(by: disposeBag)

        rootView.voiceRecordView.emojiBtn.rx.tap
            .subscribe(onNext: { [weak self] _ in
                guard let self = self else { return }
                self.rootView.dismissAllPanels()
                self.showEmojiPanel()
            })
            .disposed(by: disposeBag)
        
        // 表情面板点击
        rootView.emojiCollectionView.rx.modelSelected(String.self)
            .subscribe(onNext: { [weak self] name in
                guard let self = self, let idx = UIView.emojiFileNames.firstIndex(of: name) else { return }
                self.viewModel.input.sendMessage.onNext("js_emoji:\(idx)")
            })
            .disposed(by: disposeBag)

        // ➕按钮
        Observable.merge(
            rootView.addBtn.rx.tap.asObservable(),
            rootView.voiceRecordView.addBtn.rx.tap.asObservable()
        )
        .subscribe(onNext: { [weak self] in
            guard let self = self else { return }
            self.rootView.dismissAllPanels()
            self.showAlbum()
        })
        .disposed(by: disposeBag)
        
        rootView.sendBtn.rx.tap
            .subscribe(onNext: { [weak self] in
                guard let self = self else { return }
                let text = self.rootView.textField.text ?? ""
                guard !text.trimmingCharacters(in: .whitespacesAndNewlines).isEmpty else { return }
                self.viewModel.input.sendMessage.onNext(text)
                self.rootView.textField.text = ""
                self.hideMentionPicker()
            })
            .disposed(by: disposeBag)
        
        // 设置
        rootView.settingBtn.rx.tap
            .subscribe(onNext: { [weak self] _ in
                guard let self = self else { return }
                AppRouter.push(Route.groupSetting, userInfo: ["groupId": self.viewModel.groupId])
            })
            .disposed(by: disposeBag)
    }
    
    // MARK: - 显示语音面板
    private func showSpeakPanel() {
        let show = rootView.voiceRecordView.isHidden
        rootView.voiceRecordView.isHidden = !show
        let offset: CGFloat = show ? 252 : 0
        UIView.animate(withDuration: 0.25) {
            self.rootView.bottomBar.layoutChain.bottom(show ? offset - self.rootView.bottomBar.dl.height : kSafeBottomMargin + 20)
            self.rootView.voiceRecordView.layoutChain.bottom(offset - 252)
        }
        scrollToBottom()
    }
    
    // MARK: - 显示表情面板
    private func showEmojiPanel() {
        let show = self.rootView.emojiPanelView.isHidden
        if !show {
            self.rootView.stopVisibleEmojiAnimations()
        }
        self.rootView.emojiPanelView.isHidden = !show
        let offset: CGFloat = show ? 220 : 0
        UIView.animate(withDuration: 0.25) {
            self.rootView.bottomBar.layoutChain.bottom(20 + offset)
        }
//        completion: { _ in
//            let offset: CGFloat = self.rootView.tableView.contentSize.height
//            self.rootView.tableView.setContentOffset(CGPointMake(0, offset), animated: false)
//        }
        scrollToBottom()
        
        if show {
            self.rootView.textField.resignFirstResponder()
            DispatchQueue.main.async {
                self.rootView.playVisibleEmojiAnimations()
                self.rootView.preloadAdjacentEmojiPages()
            }
        }
    }
    
    // MARK: - 显示相册
    private func showAlbum() {
        // 设置与微信主题一致的配置
        let config = PhotoTools.getWXPickerConfig()
        // 最多可以选择的资源数，如果为0则不限制
        config.selectOptions = [.photo]
        config.selectMode = .multiple
        config.maximumSelectedCount = 9
//                config.maximumSelectedPhotoFileSize = 5242880
        config.allowSyncICloudWhenSelectPhoto = false
        config.previewView.bottomView.editButtonHidden = true
        config.photoList.allowAddCamera = true
        config.photoList.camera.allowsEditing = false
        let pickerController = PhotoPickerController(picker: config)
        pickerController.pickerDelegate = self
        pickerController.modalPresentationStyle = .fullScreen
        self.present(pickerController, animated: true, completion: nil)
    }

    // MARK: - Voice Recording
    private var audioRecorder: AVAudioRecorder?
    private var recordFileURL: URL?
    private var recordTimer: Timer?
    private var recordDuration: Int = 0
    private func setupVoiceRecording() {
        let longPress = UILongPressGestureRecognizer(target: self, action: #selector(handleVoiceLongPress(_:)))
        longPress.minimumPressDuration = 0.2
        rootView.voiceRecordView.speakBtn.addGestureRecognizer(longPress)
    }

    @objc private func handleVoiceLongPress(_ gesture: UILongPressGestureRecognizer) {
        let location = gesture.location(in: rootView.voiceRecordView)
        let btnCenterX = rootView.voiceRecordView.speakBtn.center.x
        let isCancel = location.x < btnCenterX - 100

        switch gesture.state {
        case .began:
            AudioServicesPlaySystemSound(1519)
            rootView.voiceRecordView.state = .recording
            startRecording()
        case .changed:
            let wasRecording = rootView.voiceRecordView.state == .recording
            rootView.voiceRecordView.state = isCancel ? .canceling : .recording
            rootView.voiceRecordView.cancelBtn.isSelected = isCancel
            if isCancel && wasRecording {
                AudioServicesPlaySystemSound(1519)
            }
        case .ended:
            stopRecording(cancel: isCancel)
        default:
            break
        }
    }

    private func startRecording() {
        let session = AVAudioSession.sharedInstance()
        try? session.setCategory(.playAndRecord, mode: .default)
        try? session.setActive(true)

        let dir = NSTemporaryDirectory()
        let filename = "voice_\(Int(Date().timeIntervalSince1970)).wav"
        recordFileURL = URL(fileURLWithPath: dir + filename)

        let settings: [String: Any] = [
            AVFormatIDKey: kAudioFormatLinearPCM,
            AVSampleRateKey: 8000,
            AVNumberOfChannelsKey: 1,
            AVLinearPCMBitDepthKey: 16,
            AVLinearPCMIsFloatKey: false
        ]

        guard let url = recordFileURL else { return }
        audioRecorder = try? AVAudioRecorder(url: url, settings: settings)
        audioRecorder?.record()

        recordDuration = 0
        recordTimer = Timer.scheduledTimer(withTimeInterval: 1, repeats: true) { [weak self] _ in
            self?.recordDuration += 1
        }
    }

    private func stopRecording(cancel: Bool) {
        audioRecorder?.stop()
        recordTimer?.invalidate()
        recordTimer = nil
        rootView.voiceRecordView.stopRotating()
        
        try? AVAudioSession.sharedInstance().setActive(false)

        if cancel {
            self.rootView.voiceRecordView.cancelBtn.isSelected = false
            if let url = recordFileURL { try? FileManager.default.removeItem(at: url) }
            return
        }

        guard let url = recordFileURL, recordDuration >= 1 else {
            self.dl.show(text: "说话时间太短")
            if let url = recordFileURL { try? FileManager.default.removeItem(at: url) }
            return
        }

        // Send voice message via OpenIM
        let msg = OIMMessageInfo.createSoundMessage(fromFullPath: url.path, duration: recordDuration * 1000)
        viewModel.cacheMessage(msg)
        OIMManager.manager.sendMessage(msg,
                                       recvID: "",
                                       groupID: viewModel.groupId,
                                       offlinePushInfo: nil,
                                       onSuccess: { [weak self] _ in
            self?.viewModel.onReceiveMessage(msg)
        },
                                       onProgress: nil as OIMNumberCallback?,
                                       onFailure: { code, errMsg in
            print("Voice send failed: \(code) \(errMsg ?? "")")
        })
    }

    // MARK: - API
    private func requestGroupInfoByKey() {
        GroupService.groupInfoByKey(viewModel.groupId).subscribe { response in
            guard let model = response.model else { return }
            self.viewModel.memberList = response.list
            self.rootView.groupNameLabel.text = model.name
            self.rootView.groupAvatarView.image = model.groupIcon
            self.rootView.reviewBtn.isHidden = !model.is_owner
            self.rootView.reviewDotView.isHidden = response.reviewCount == 0
        }.disposed(by: disposeBag)
    }
    
    // MARK: - dataSource
    private lazy var dataSource: RxTableViewSectionedReloadDataSource<ChatSectionModel> = {
        RxTableViewSectionedReloadDataSource<ChatSectionModel> { [weak self] _, tableView, indexPath, item in
            switch item {
            case let .send(msg):
                let cell: TextSendMsgCell = tableView.dequeueReusableCell(for: indexPath)
                cell.configure(msg)
                cell.onQuoteTap = { [weak self] in
                    guard let id = msg.quotePreview?.quotedClientMsgID else { return }
                    self?.scrollToMessage(clientMsgID: id)
                }
                return cell
            case let .received(msg):
                let cell: TextReceivedMsgCell = tableView.dequeueReusableCell(for: indexPath)
                cell.configure(msg)
                cell.onQuoteTap = { [weak self] in
                    guard let id = msg.quotePreview?.quotedClientMsgID else { return }
                    self?.scrollToMessage(clientMsgID: id)
                }
                return cell
            case let .emojiSend(msg):
                let cell: EmojiSendMsgCell = tableView.dequeueReusableCell(for: indexPath)
                cell.configure(msg)
                return cell
            case let .emojiReceived(msg):
                let cell: EmojiReceivedMsgCell = tableView.dequeueReusableCell(for: indexPath)
                cell.configure(msg)
                return cell
            case let .voiceSend(msg):
                let cell: VoiceSendMsgCell = tableView.dequeueReusableCell(for: indexPath)
                cell.configure(msg)
                return cell
            case let .voiceReceived(msg):
                let cell: VoiceReceivedMsgCell = tableView.dequeueReusableCell(for: indexPath)
                cell.configure(msg)
                return cell
            case let .imageSend(msg):
                let cell: ImageSendMsgCell = tableView.dequeueReusableCell(for: indexPath)
                cell.configure(msg)
                cell.onImageTap = { [weak self] in
                    self?.showBigImage(imgUrlList: [msg.imageUrl], currentPage: 0, projectiveView: cell.photoView)
                }
                return cell
            case let .imageReceived(msg):
                let cell: ImageReceivedMsgCell = tableView.dequeueReusableCell(for: indexPath)
                cell.configure(msg)
                cell.onImageTap = { [weak self] in
                    self?.showBigImage(imgUrlList: [msg.imageUrl], currentPage: 0, projectiveView: cell.photoView)
                }
                return cell
            case let .notification(text, showTime, timestamp),
                 let .revoked(text, showTime, timestamp):
                let cell: NotificationMsgCell = tableView.dequeueReusableCell(for: indexPath)
                cell.configure(text, showTime: showTime, timestamp: timestamp)
                return cell
            }
        }
    }()
}

// MARK: - UITextFieldDelegate / Mention table
extension GroupChatVC: UITextFieldDelegate, UITableViewDataSource {
    func textFieldShouldReturn(_ textField: UITextField) -> Bool {
        let text = textField.text ?? ""
        guard !text.trimmingCharacters(in: .whitespacesAndNewlines).isEmpty else { return true }
        viewModel.input.sendMessage.onNext(text)
        textField.text = ""
        hideMentionPicker()
        return true
    }

    func numberOfSections(in tableView: UITableView) -> Int { 1 }

    func tableView(_ tableView: UITableView, numberOfRowsInSection section: Int) -> Int {
        tableView === rootView.mentionTableView ? mentionRows.count : 0
    }

    func tableView(_ tableView: UITableView, cellForRowAt indexPath: IndexPath) -> UITableViewCell {
        let cell = tableView.dequeueReusableCell(withIdentifier: "MentionCell", for: indexPath)
        let row = mentionRows[indexPath.row]
        cell.textLabel?.font = .systemFont(ofSize: 14)
        cell.textLabel?.text = row.userId == nil ? "@所有人" : "@\(row.nickname)"
        cell.selectionStyle = .default
        return cell
    }
}

// MARK: - UITableViewDelegate
extension GroupChatVC: UITableViewDelegate {
    func tableView(_ tableView: UITableView, willDisplay cell: UITableViewCell, forRowAt indexPath: IndexPath) {
        (cell as? EmojiSendMsgCell)?.playAnimation()
        (cell as? EmojiReceivedMsgCell)?.playAnimation()
    }

    func tableView(_ tableView: UITableView, didEndDisplaying cell: UITableViewCell, forRowAt indexPath: IndexPath) {
        (cell as? EmojiSendMsgCell)?.stopAnimation()
        (cell as? EmojiReceivedMsgCell)?.stopAnimation()
    }

    func tableView(_ tableView: UITableView, didSelectRowAt indexPath: IndexPath) {
        guard tableView === rootView.mentionTableView else { return }
        tableView.deselectRow(at: indexPath, animated: true)
        let row = mentionRows[indexPath.row]
        insertMention(userId: row.userId, nickname: row.nickname)
    }
}

// MARK: - MessageListenerProxy
private class MessageListenerProxy: NSObject, OIMAdvancedMsgListener {
    private let onMessage: (OIMMessageInfo) -> Void
    private let onRevoked: (OIMMessageRevokedInfo) -> Void

    init(onMessage: @escaping (OIMMessageInfo) -> Void,
         onRevoked: @escaping (OIMMessageRevokedInfo) -> Void) {
        self.onMessage = onMessage
        self.onRevoked = onRevoked
    }

    func onRecvNewMessage(_ msg: OIMMessageInfo) {
        onMessage(msg)
    }

    func onRecvMessageRevoked(_ messageRevoked: OIMMessageRevokedInfo) {
        onRevoked(messageRevoked)
    }
}

// MARK: - PhotoPickerControllerDelegate
extension GroupChatVC: PhotoPickerControllerDelegate {
    /// 选择完成之后调用
    /// - Parameters:
    ///   - pickerController: 对应的 PhotoPickerController
    ///   - result: 选择的结果
    ///     result.photoAssets  选择的资源数组
    ///     result.isOriginal   是否选中原图
    func pickerController(_ pickerController: PhotoPickerController,
                            didFinishSelection result: PickerResult) {
        result.getImage { (image, photoAsset, index) in
        } completionHandler: { [weak self] (images) in
            guard let self = self else { return }
            for img in images {
                self.sendImageMessage(img)
            }
        }
    }

    private func sendImageMessage(_ image: UIImage) {
        guard let data = image.jpegData(compressionQuality: 0.8) else { return }
        let dir = NSTemporaryDirectory()
        let filename = "img_\(Int(Date().timeIntervalSince1970)).jpg"
        let fileURL = URL(fileURLWithPath: dir + filename)
        try? data.write(to: fileURL)

        let displaySize = Self.imageDisplaySize(w: image.size.width, h: image.size.height)

        let msg = OIMMessageInfo.createImageMessage(fromFullPath: fileURL.path)
        // 使用 SDK 的 clientMsgID 作为本地消息 ID，方便后续与监听器去重
        let localId = msg.clientMsgID ?? UUID().uuidString
        viewModel.cacheMessage(msg)

        // 立即显示本地图片（带 loading）
        let localMsg = ChatMessage(
            id: localId,
            isSelf: true,
            senderId: AppContextManager.shared.userId,
            avatar: viewModel.getUserAvatar(id: AppContextManager.shared.userId),
            senderName: AppContextManager.shared.name,
            content: "",
            voiceUrl: "",
            imageUrl: fileURL.path,
            imageWidth: displaySize.width,
            imageHeight: displaySize.height,
            timestamp: Date().timeIntervalSince1970,
            showTime: false,
            isUploading: true
        )
        viewModel.appendLocalMessage(.imageSend(localMsg))
        OIMManager.manager.sendMessage(msg,
                                       recvID: "",
                                       groupID: viewModel.groupId,
                                       offlinePushInfo: nil,
                                       onSuccess: { [weak self] returnedMsg in
            // 服务端返回后，更新本地消息为服务端图片URL，去掉loading
            // 注意：returnedMsg 是 SDK 回填服务端数据后的新 OIMMessageInfo，包含完整 URL
            let networkUrl = returnedMsg?.pictureElem?.sourcePicture?.url
                ?? returnedMsg?.pictureElem?.bigPicture?.url
                ?? returnedMsg?.pictureElem?.sourcePath
                ?? ""
            self?.viewModel.updateLocalMessage(id: localId) { chatMsg in
                // 仅在服务端有URL时才替换，否则保留本地路径让图片仍可见
                if !networkUrl.isEmpty {
                    chatMsg.imageUrl = networkUrl
                }
                chatMsg.isUploading = false
            }
            try? FileManager.default.removeItem(at: fileURL)
        },
                                       onProgress: nil as OIMNumberCallback?,
                                       onFailure: { [weak self] code, errMsg in
            print("Image send failed: \(code) \(errMsg ?? "")")
            // 发送失败，隐藏 loading
            self?.viewModel.updateLocalMessage(id: localId) { chatMsg in
                chatMsg.isUploading = false
            }
        })
    }

    private static func imageDisplaySize(w: CGFloat, h: CGFloat) -> CGSize {
        guard w > 0, h > 0 else { return CGSize(width: 160, height: 160) }
        let maxW: CGFloat = 200, maxH: CGFloat = 250, minW: CGFloat = 80
        var dw = maxW, dh = dw * (h / w)
        if dh > maxH { dh = maxH; dw = dh * (w / h) }
        if dw < minW { dw = minW; dh = dw * (h / w) }
        return CGSize(width: dw, height: dh)
    }
    
    /// 点击取消时调用
    /// - Parameter pickerController: 对应的 PhotoPickerController
    func pickerController(didCancel pickerController: PhotoPickerController) {
        
    }
}