music(player): 收藏功能 — title 旁 ★/☆，收藏的曲目置顶

apps/music/src/main.rs

@@ -135,6 +135,11 @@ async fn main() -> std::io::Result<()> {
          CREATE INDEX IF NOT EXISTS idx_pp_piece ON playlist_pieces(piece_id);",
     )
     .expect("init schema");
+    // 兼容旧 db：增量加 favorite 列
+    let _ = conn.execute(
+        "ALTER TABLE pieces ADD COLUMN favorite INTEGER NOT NULL DEFAULT 0",
+        [],
+    );
     tracing::info!(%db_path, blobs = %blobs_dir.display(), "music ready");
 
     let chord_url =
@@ -216,6 +221,7 @@ struct PieceSummary {
     kinds: Vec<String>,
     tags: Vec<String>,
     has_lyrics: bool,
+    favorite: bool,
     created_at: String,
 }
 
@@ -232,6 +238,7 @@ struct PieceDetail {
     created_at: String,
     attachments: Vec<Attachment>,
     tags: Vec<String>,
+    favorite: bool,
 }
 
 #[derive(Serialize)]
@@ -271,6 +278,7 @@ struct PatchPiece {
     tags: Option<Vec<String>>,
     /// admin / import 用：直接写 play_count（mvp 无认证）
     play_count: Option<i64>,
+    favorite: Option<bool>,
 }
 
 #[derive(Deserialize, Default)]
@@ -312,12 +320,13 @@ async fn list_pieces(
                 CASE WHEN p.lyrics IS NOT NULL AND length(p.lyrics) > 0 THEN 1 ELSE 0 END AS has_lyrics,
                 COALESCE((SELECT GROUP_CONCAT(t.name, char(9))
                           FROM piece_tags pt2 JOIN tags t ON t.id = pt2.tag_id
-                          WHERE pt2.piece_id = p.id), '') AS tags
+                          WHERE pt2.piece_id = p.id), '') AS tags,
+                COALESCE(p.favorite, 0) AS favorite
          FROM pieces p
          {filter_join}
          {filter_where}
          GROUP BY p.id
-         ORDER BY p.title COLLATE NOCASE ASC, p.id ASC"
+         ORDER BY p.favorite DESC, p.title COLLATE NOCASE ASC, p.id ASC"
     );
     let mut stmt = conn.prepare(&sql)?;
     let bind_refs: Vec<&dyn rusqlite::ToSql> = bind.iter().map(|v| v as &dyn rusqlite::ToSql).collect();
@@ -336,6 +345,7 @@ async fn list_pieces(
                 tags_raw.split('\t').map(|x| x.to_string()).collect()
             };
             let has_lyrics: i64 = r.get(9)?;
+            let fav: i64 = r.get(11)?;
             Ok(PieceSummary {
                 id: r.get(0)?,
                 title: r.get(1)?,
@@ -348,6 +358,7 @@ async fn list_pieces(
                 kinds,
                 tags,
                 has_lyrics: has_lyrics != 0,
+                favorite: fav != 0,
             })
         })?
         .collect::<Result<Vec<_>, _>>()?;
@@ -392,10 +403,12 @@ async fn get_piece(
         i64,
         Option<String>,
         String,
+        i64,
     );
     let row: Option<PieceRow> = conn
         .query_row(
-            "SELECT title, artist, category, notes, lyrics, play_count, last_played_at, created_at
+            "SELECT title, artist, category, notes, lyrics, play_count, last_played_at, created_at,
+                    COALESCE(favorite, 0)
              FROM pieces WHERE id = ?1",
             params![id],
             |r| {
@@ -408,11 +421,12 @@ async fn get_piece(
                     r.get(5)?,
                     r.get(6)?,
                     r.get(7)?,
+                    r.get(8)?,
                 ))
             },
         )
         .optional()?;
-    let (title, artist, category, notes, lyrics, play_count, last_played_at, created_at) =
+    let (title, artist, category, notes, lyrics, play_count, last_played_at, created_at, favorite) =
         row.ok_or(AppError::NotFound)?;
 
     let mut stmt = conn.prepare(
@@ -456,6 +470,7 @@ async fn get_piece(
         created_at,
         attachments,
         tags,
+        favorite: favorite != 0,
     }))
 }
 
@@ -516,6 +531,12 @@ async fn patch_piece(
             params![pc, id],
         )?;
     }
+    if let Some(fav) = body.favorite {
+        conn.execute(
+            "UPDATE pieces SET favorite = ?1 WHERE id = ?2",
+            params![fav as i64, id],
+        )?;
+    }
     if let Some(tags) = body.tags {
         conn.execute(
             "DELETE FROM piece_tags WHERE piece_id = ?1",