diff --git a/app/src/main/java/com/xiaoqu/watch/app/MainActivity.kt b/app/src/main/java/com/xiaoqu/watch/app/MainActivity.kt index 96a7038..fc0d741 100644 --- a/app/src/main/java/com/xiaoqu/watch/app/MainActivity.kt +++ b/app/src/main/java/com/xiaoqu/watch/app/MainActivity.kt @@ -7,16 +7,9 @@ import android.view.View import androidx.activity.OnBackPressedCallback import androidx.appcompat.app.AppCompatActivity import com.xiaoqu.watch.databinding.ActivityMainBinding -import com.xiaoqu.watch.event.AppEvent -import com.xiaoqu.watch.event.EventBus -import com.xiaoqu.watch.service.manager.NotificationManager import com.xiaoqu.watch.service.manager.SystemStateMonitor import com.xiaoqu.watch.ui.widget.NotificationBannerView import dagger.hilt.android.AndroidEntryPoint -import kotlinx.coroutines.CoroutineScope -import kotlinx.coroutines.Dispatchers -import kotlinx.coroutines.SupervisorJob -import kotlinx.coroutines.launch import timber.log.Timber import javax.inject.Inject import kotlin.math.abs @@ -32,17 +25,9 @@ class MainActivity : AppCompatActivity() { /** 系统状态监听器（电量、蓝牙状态） */ @Inject lateinit var systemStateMonitor: SystemStateMonitor - /** 消息通知管理器 */ - @Inject lateinit var notificationManager: NotificationManager - /** 事件总线 */ - @Inject lateinit var eventBus: EventBus - - /** 通知横幅（HomeFragment 需访问设置点击回调） */ + /** 通知横幅（HomeFragment 需访问） */ lateinit var notificationBanner: NotificationBannerView - /** Activity 协程作用域 */ - private val activityScope = CoroutineScope(Dispatchers.Main + SupervisorJob()) - override fun onCreate(savedInstanceState: Bundle?) { super.onCreate(savedInstanceState) @@ -68,9 +53,6 @@ class MainActivity : AppCompatActivity() { // 初始化通知横幅 notificationBanner = binding.notificationBanner - // 监听 MQTT 新任务消息，显示横幅 - observeMqttMessages() - Timber.d("MainActivity created") } @@ -80,27 +62,12 @@ class MainActivity : AppCompatActivity() { notificationBanner.destroy() } - // ===== MQTT 新任务 → 通知横幅 ===== + // ===== 通知横幅（由 HomeFragment 调用显示） ===== - /** 监听 MQTT 消息和通知事件 */ - private fun observeMqttMessages() { - activityScope.launch { - eventBus.events.collect { event -> - when (event) { - is AppEvent.MqttMessageReceived -> { - if (event.type == 1) { - // 交给 NotificationManager 处理（去抖+合并+震动+亮屏） - notificationManager.onNewTaskMessage(event.rawJson) - } - } - // NotificationManager 处理完后发出事件 → 显示/更新横幅 - is AppEvent.NewTaskArrived -> { - notificationBanner.show(event.count) - } - else -> {} - } - } - } + /** 显示通知横幅（供 HomeFragment 调用） */ + fun showNotificationBanner(count: Int) { + notificationBanner.show(count) + } } // ===== 下拉手势检测（Activity 级别，不可能被子 View 拦截） ===== diff --git a/app/src/main/java/com/xiaoqu/watch/service/manager/NotificationManager.kt b/app/src/main/java/com/xiaoqu/watch/service/manager/NotificationManager.kt index 0d946ad..ffbfdda 100644 --- a/app/src/main/java/com/xiaoqu/watch/service/manager/NotificationManager.kt +++ b/app/src/main/java/com/xiaoqu/watch/service/manager/NotificationManager.kt @@ -4,8 +4,6 @@ import com.xiaoqu.watch.data.task.TaskStatistics import com.xiaoqu.watch.device.screen.ScreenController import com.xiaoqu.watch.device.sensor.VibrationController import com.xiaoqu.watch.device.sensor.VibrationDefaults -import com.xiaoqu.watch.event.AppEvent -import com.xiaoqu.watch.event.EventBus import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.Dispatchers import kotlinx.coroutines.SupervisorJob @@ -27,8 +25,7 @@ import javax.inject.Singleton @Singleton class NotificationManager @Inject constructor( private val vibrationController: VibrationController, - private val screenController: ScreenController, - private val eventBus: EventBus + private val screenController: ScreenController ) { companion object { /** 去抖间隔（毫秒） */ @@ -73,6 +70,9 @@ class NotificationManager @Inject constructor( /** 协程作用域 */ private val scope = CoroutineScope(Dispatchers.Main + SupervisorJob()) + /** 去抖合并后的回调（通知 UI 更新横幅数字） */ + var onPendingCountChanged: ((Int) -> Unit)? = null + /** * 处理 MQTT type=1 新任务消息 * 去抖策略：1s 窗口内的消息暂存，窗口结束后合并处理（不丢弃） @@ -104,8 +104,8 @@ class NotificationManager @Inject constructor( for (json in jsons) { processMessageSilent(json) // 只加 ID，不重复震动 } - // 合并后统一发一次事件 - notifyUi() + // 合并后通知 UI 更新数字 + onPendingCountChanged?.invoke(pendingCount) } } } @@ -128,8 +128,7 @@ class NotificationManager @Inject constructor( vibrationController.executePattern(pattern) } screenController.turnOn() - - notifyUi() + // UI 更新（横幅+红点）由调用方处理，不再通过 EventBus } /** 静默处理（只加 ID，不震动不亮屏，用于合并暂存消息） */ @@ -149,12 +148,7 @@ class NotificationManager @Inject constructor( Timber.d("通知: 当前未读 ${_pendingTaskIds.size}") } - /** 通知 UI 更新（横幅+红点） */ - private fun notifyUi() { - scope.launch { - eventBus.emit(AppEvent.NewTaskArrived(_pendingTaskIds.toList(), _pendingTaskIds.size)) - } - } + // notifyUi 已移除，UI 更新改由调用方（HomeFragment）直接处理 /** 消费所有未读消息（用户点击提示条/横幅查看全部） */ fun consumeAll() { diff --git a/app/src/main/java/com/xiaoqu/watch/ui/home/HomeFragment.kt b/app/src/main/java/com/xiaoqu/watch/ui/home/HomeFragment.kt index 62a77e0..a19b025 100644 --- a/app/src/main/java/com/xiaoqu/watch/ui/home/HomeFragment.kt +++ b/app/src/main/java/com/xiaoqu/watch/ui/home/HomeFragment.kt @@ -130,6 +130,12 @@ class HomeFragment : BaseFragment() { // 监听打卡状态 observePunchState() + + // 去抖合并后更新横幅数字 + notificationManager.onPendingCountChanged = { count -> + (activity as? com.xiaoqu.watch.app.MainActivity)?.showNotificationBanner(count) + fetchStatistics(checkDots = true) + } } override fun onResume() { @@ -175,12 +181,13 @@ class HomeFragment : BaseFragment() { override fun onDestroyView() { super.onDestroyView() - // 清理 Activity 回调，避免泄漏 + // 清理回调，避免泄漏 (activity as? com.xiaoqu.watch.app.MainActivity)?.let { it.onSwipeDown = null it.onBackKeyPressed = null it.notificationBanner.onClick = null } + notificationManager.onPendingCountChanged = null } // ===== 打卡面板 ===== @@ -484,12 +491,6 @@ class HomeFragment : BaseFragment() { is AppEvent.BluetoothStateChanged -> { statusBar.updateBluetooth(event.isOn) } - // 新任务到达 → 刷新统计 + 累积红点 - is AppEvent.NewTaskArrived -> { - Timber.d("首页: 新任务到达 (${event.count} 条)") - fetchStatistics(checkDots = true) - setupBannerClick() - } // MQTT 消息 is AppEvent.MqttMessageReceived -> { when (event.type) { @@ -498,6 +499,20 @@ class HomeFragment : BaseFragment() { Timber.d("首页: 收到日常动态") fetchStatistics() } + 1 -> { + // 新任务 → 直接处理（不走中间事件，避免 SharedFlow 竞争） + Timber.d("首页: 收到新任务通知") + notificationManager.onNewTaskMessage(event.rawJson) + // 显示横幅 + val count = notificationManager.pendingCount + if (count > 0) { + (activity as? com.xiaoqu.watch.app.MainActivity) + ?.showNotificationBanner(count) + } + // 刷新统计 + 红点 + fetchStatistics(checkDots = true) + setupBannerClick() + } 3 -> { // 解绑 → 停止蓝牙 → 清除数据 → 跳绑定页 Timber.d("首页: 收到解绑消息")