Firebase Realtime Database：实现数据即时同步与警报设置

import com.google.firebase.database.DataSnapshot;
import com.google.firebase.database.DatabaseError;
import com.google.firebase.database.DatabaseReference;
import com.google.firebase.database.FirebaseDatabase;
import com.google.firebase.database.ValueEventListener;
import androidx.annotation.NonNull;
import android.util.Log;

public class AlarmManager {

    private DatabaseReference alarmRef;
    private ValueEventListener alarmListener;
    private String currentUserId; // 假设这是当前用户的ID

    public AlarmManager(String userId) {
        this.currentUserId = userId;
        // 获取Firebase数据库中"Alarm"节点的引用
        alarmRef = FirebaseDatabase.getInstance().getReference("Alarm");
        // 启用数据离线持久化和同步，即使网络断开也能访问最近同步的数据
        FirebaseDatabase.getInstance().setPersistenceEnabled(true);
        alarmRef.keepSynced(true); // 保持此节点数据与服务器同步
    }

    /**
     * 开始监听当前用户的警报数据变化
     */
    public void startListeningForAlarms() {
        // 创建一个ValueEventListener
        alarmListener = new ValueEventListener() {
            @Override
            public void onDataChange(@NonNull DataSnapshot snapshot) {
                // 检查当前用户ID是否存在于快照中
                if (snapshot.hasChild(currentUserId)) {
                    DataSnapshot userAlarmSnapshot = snapshot.child(currentUserId);

                    // 从快照中获取警报ID、小时和分钟
                    // 注意：这里需要根据实际数据结构进行调整
                    // 如果id是子节点，需要 userAlarmSnapshot.child("id").getValue(String.class)
                    // 假设id就是currentUserId，或者存储在某个字段中
                    String alarmId = userAlarmSnapshot.getKey(); // 获取当前用户的节点键作为警报ID
                    String hour = userAlarmSnapshot.child("hour").getValue(String.class); // 获取小时
                    String minute = userAlarmSnapshot.child("minute").getValue(String.class); // 获取分钟

                    Log.d("AlarmManager", "Received Alarm for ID: " + alarmId);
                    Log.d("AlarmManager", "Hour: " + hour + ", Minute: " + minute);

                    // 在这里处理接收到的警报数据，例如：
                    // 1. 解析小时和分钟，转换为整数
                    // 2. 使用Android的AlarmManager服务设置本地警报
                    // 3. 更新UI（如果应用在前台）
                    // 4. 发送本地通知（如果应用在后台）
                    setLocalAlarm(Integer.parseInt(hour), Integer.parseInt(minute));

                } else {
                    Log.d("AlarmManager", "No alarm data found for user ID: " + currentUserId);
                }
            }

            @Override
            public void onCancelled(@NonNull DatabaseError error) {
                // 处理监听器取消或失败的情况
                Log.e("AlarmManager", "Alarm data listener cancelled or failed: " + error.getMessage());
                // 根据错误类型采取适当措施，例如重试连接或通知用户
            }
        };

        // 将监听器添加到指定的用户ID路径
        // 这样只监听特定用户的数据变化，而不是整个"Alarm"节点
        alarmRef.child(currentUserId).addValueEventListener(alarmListener);
    }

    /**
     * 停止监听警报数据变化，避免内存泄漏和不必要的网络消耗
     */
    public void stopListeningForAlarms() {
        if (alarmRef != null && alarmListener != null) {
            alarmRef.child(currentUserId).removeEventListener(alarmListener);
            Log.d("AlarmManager", "Alarm listener removed for user ID: " + currentUserId);
        }
    }

    /**
     * 模拟设置本地警报的方法
     * 实际应用中会调用Android的AlarmManager服务
     */
    private void setLocalAlarm(int hour, int minute) {
        Log.i("AlarmManager", "Setting local alarm for " + hour + ":" + minute);
        // 实际的警报设置逻辑，例如：
        // Intent alarmIntent = new Intent(context, AlarmReceiver.class);
        // PendingIntent pendingIntent = PendingIntent.getBroadcast(context, 0, alarmIntent, 0);
        // AlarmManager am = (AlarmManager) context.getSystemService(Context.ALARM_SERVICE);
        // Calendar calendar = Calendar.getInstance();
        // calendar.setTimeInMillis(System.currentTimeMillis());
        // calendar.set(Calendar.HOUR_OF_DAY, hour);
        // calendar.set(Calendar.MINUTE, minute);
        // calendar.set(Calendar.SECOND, 0);
        // am.setExact(AlarmManager.RTC_WAKEUP, calendar.getTimeInMillis(), pendingIntent);
    }

    // 在Activity或Service的生命周期方法中调用
    // 例如：
    // @Override
    // protected void onStart() {
    //     super.onStart();
    //     alarmManager.startListeningForAlarms();
    // }
    //
    // @Override
    // protected void onStop() {
    //     super.onStop();
    //     alarmManager.stopListeningForAlarms();
    // }
}