Flutter Firebase场景下1年后自动更新Cloud Firestore订阅状态字段的方法

要实现订阅到期自动改状态的需求，你需要先补充存储订阅到期时间的字段，再搭配Cloud Functions for Firebase的定时调度功能完成自动更新，具体实现步骤如下：

1. 调整支付成功后的Firestore写入逻辑 #

仅存储subscribed: true无法判断订阅到期时间，需要新增expireAt字段存储1年后的到期时间戳，写入示例（Web端SDK）：

import { doc, setDoc, Timestamp } from "firebase/firestore"; 
const userId = "当前登录用户的唯一ID";
const userSubRef = doc(db, "subscriptions", userId);

// 支付成功后写入数据
await setDoc(userSubRef, {
  subscribed: true,
  // 计算当前时间加1年的时间戳作为到期时间
  expireAt: Timestamp.fromDate(new Date(Date.now() + 365 * 24 * 60 * 60 * 1000))
}, { merge: true });

2. 编写定时调度的Cloud Function #

通过每天定时执行的云函数，批量更新所有到期的订阅状态：

const functions = require("firebase-functions");
const admin = require("firebase-admin");
admin.initializeApp();
const db = admin.firestore();

// 每天UTC时间0点执行，处理过期订阅
exports.expireSubscriptions = functions.pubsub.schedule("every 24 hours").onRun(async () => {
  const currentTime = admin.firestore.Timestamp.now();
  // 查询所有已到期但仍标记为已订阅的记录
  const expiredSubs = await db.collection("subscriptions")
    .where("subscribed", "==", true)
    .where("expireAt", "<", currentTime)
    .get();

  // 批量更新字段
  const writeBatch = db.batch();
  expiredSubs.docs.forEach(doc => {
    writeBatch.update(doc.ref, { subscribed: false });
  });
  await writeBatch.commit();

  console.log(`成功更新${expiredSubs.size}条过期订阅记录`);
  return null;
});

可选优化项 #

• 若需要更精准的到期触发，可以将调度频率调整为每小时/每分钟执行
• 用户量较大时需给查询添加分页逻辑，避免单次查询数据量超限
• 前端可以新增本地校验逻辑，用户打开App时先比对当前时间和expireAt字段，提前识别过期状态，不用等云函数执行

内容的提问来源于stack exchange，提问作者Wali Khan