934 lines
38 KiB
Swift
934 lines
38 KiB
Swift
//
|
||
// 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) {
|
||
|
||
}
|
||
}
|