Function getShiftRule

shift/shift.ts:297–342

(sourceId: number)

    if (useLowdb && lowdb) {
      // 从 lowdb 读取
      const data = lowdb.data.rules[String(sourceId)];
      rule = data || null;
    } else if (sqliteDb) {
      // 从 SQLite 读取
      const stmt = sqliteDb.prepare(
        "SELECT * FROM shift_rules WHERE source_id = ?"
      );
      const row = stmt.get(sourceId) as any;

      if (!row) {
        ruleCache.set(sourceId, { rule: null, timestamp: now });
        return null;
      }

      rule = {
        target_id: row.target_id,
        options: JSON.parse(row.options || "[]"),
        target_type: row.target_type,
        paused: row.paused === 1,
        created_at: row.created_at,
        filters: JSON.parse(row.filters || "[]"),
      };
    }

    if (rule) {
      ruleCache.set(sourceId, { rule, timestamp: now });
    }
    return rule;
  } catch (error) {
    console.error(`[SHIFT] Error getting rule for ${sourceId}:`, error);
    return null;
  }
}

// Save shift rule
function saveShiftRule(sourceId: number, rule: ShiftRule): boolean {
  try {
    if (useLowdb && lowdb) {
      // 保存到 lowdb
      lowdb.data.rules[String(sourceId)] = rule;
      lowdb.write();
      ruleCache.set(sourceId, { rule, timestamp: Date.now() });
      return true;
    } else if (sqliteDb) {
      // 保存到 SQLite
      const stmt = sqliteDb.prepare(`
      INSERT OR REPLACE INTO shift_rules 
      (source_id, target_id, options, target_type, paused, created_at, filters)
      VALUES (?, ?, ?, ?, ?, ?, ?)