merge: 合并奖励中心与我的页视觉优化

- 登录页保留邮箱与 Google 两个入口，Google 按钮按官方规范改为白底四色图标
- 新增 GoogleAuthService：封装 initialize/authenticate，失败以结果对象返回
- AuthApi 增加 googleLogin，AuthController 增加 signInWithGoogle
- iOS 补充 CFBundleURLTypes 与 GIDClientID，Bundle ID 统一为 com.stormg.lumadrama
- Google 请求期间按钮显示转圈并禁止重复点击

.gitea/workflows/ci.yml

@@ -0,0 +1,25 @@
+# Author: fruit.com.cn
+# ReelShort 客户端 CI：静态分析 + 测试门禁
+name: flutter-ci
+
+on:
+  push:
+    branches: [develop, main]
+  pull_request:
+    branches: [develop, main]
+
+jobs:
+  test:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: subosito/flutter-action@v2
+        with:
+          channel: stable
+          cache: true
+      - name: 依赖
+        run: flutter pub get
+      - name: 静态分析（零告警门禁）
+        run: dart analyze --fatal-infos
+      - name: 单元测试（全绿门禁）
+        run: flutter test -r expanded

.gitignore

@@ -65,3 +65,6 @@ app.*.map.json
 .env
 .env.*
 !.env.example
+
+# IDE 的 Flutter Widget Preview 生成目录。
+.widget_preview/

README.md

@@ -1,18 +1,22 @@
 # FruitShorts（ReelShort）客户端
 
-FruitShorts 是面向印尼市场的短剧 Flutter 客户端。当前版本已连接
+FruitShorts 是面向印尼市场的短剧 Flutter 客户端，已连接 `FruitServer` 的
-`FruitServer` 的 `/app/**` 接口，支持沉浸播放、找剧、账号、观看记录、收藏、
+`/app/**` 接口。功能覆盖：四 tab 主页（推荐视频流 / 找剧 / 追剧 / 我的）、
-下载授权、评论互动、站内通知和中英印尼三语界面。
+沉浸式播放与全屏剧集播放器、清晰度切换、剧单与排行榜、新剧页、搜索、观看记录、
+收藏短剧、评论与点赞、站内通知、钱包与商品、下载落盘与离线播放、中英印尼三语，
+以及 Android / iOS 双端画中画（退到后台自动进小窗）。
 
 ## 技术栈
 
-- Flutter 3.47.7 / Dart 3.13.5
+- Flutter 3.47.7 / Dart 3.13.5（`environment.sdk: ^3.12.2`）
 - Provider 状态管理与依赖注入
 - dio 网络请求
 - video_player 播放
 - shared_preferences 与 `SharedPreferencesAsync` 本地配置
+- path_provider + dart:io 下载落盘（先写 `.part`，完成后原子改名）
 - flutter_localizations，支持 `en`、`zh`、`id`
-- Android 系统画中画
+- 画中画：Android 用 `floating` + `permission_handler`（需悬浮窗权限）；
+  iOS 用原生 `AVPictureInPictureController` + 影子播放器（`ios/Runner/AppDelegate.swift`）
 
 ## 目录结构
 
@@ -22,7 +26,7 @@ lib/
     config/       地址、语言和运行时配置
     data/         models、remote API、repository、controller
     formatting/   文案与日期格式化
-    platform/     触觉等平台能力
+    platform/     平台能力：画中画通道、设备号、触觉
     theme/        颜色与主题
     widgets/      跨页面复用组件
   l10n/           三语 ARB 与生成代码
@@ -36,20 +40,21 @@ assets/           图标、图片和本地媒体文件
 
 ## 已接接口
 
-以下接口均在 `lib/core/data/remote/` 中有实际调用，共 26 个不同路径、
+以下接口均在 `lib/core/data/remote/` 中有实际调用，共 47 个不同路径。
-31 个 HTTP 方法级调用。
 
-| 分组 | 契约 | 接口 |
+| 分组 | 接口 |
-| --- | --- | --- |
+| --- | --- |
-| 账号 | §1.1 | `POST /app/auth/register`、`/login`、`/refresh`、`/logout` |
+| 账号 | `POST /app/auth/register`、`/login`、`/refresh`、`/logout`、`/otp`；`GET /app/me`、`/app/me/devices`、`/app/me/export`；`POST /app/me/deactivate`、`/app/me/deactivate/cancel` |
-| 内容 | §1.3、§1.4 | `GET /app/home/feed`、`/app/discover/feed`、`/app/categories`、`/app/dramas/{id}`、`/app/episodes/{id}/play` |
+| 内容 | `GET /app/home/feed`、`/app/feed`、`/app/discover/feed`、`/app/categories`、`/app/categories/{id}/dramas`、`/app/drama-categories`、`/app/dramas/page`、`/app/dramas/{id}`、`/app/tags`、`/app/search`、`/app/playlists`、`/app/playlists/{id}` |
-| 观看记录 | §1.5 | `POST/GET /app/watch/progress`、`GET /app/watch/recent`、`DELETE /app/watch/progress/{dramaId}`、`DELETE /app/watch/progress` |
+| 播放 | `GET /app/episodes/{id}/play`、`/app/episodes/{id}/stats`；`POST /app/episodes/{id}/unlock` |
-| 收藏 | §1.5 | `POST /app/favorites/toggle`、`GET /app/favorites`、`DELETE /app/favorites/{dramaId}` |
+| 观看记录 | `POST/GET /app/watch/progress`、`GET /app/watch/recent`、`DELETE /app/watch/progress/{dramaId}`、`DELETE /app/watch/progress` |
-| 下载授权 | §1.6 | `GET /app/downloads/policy`、`PUT /app/downloads/settings`、`POST/GET /app/downloads`、`GET /app/downloads/{episodeId}/url`、`POST /app/downloads/{episodeId}/progress`、`DELETE /app/downloads/{episodeId}`、`DELETE /app/downloads` |
+| 收藏 | `POST /app/favorites/toggle`、`GET /app/favorites`、`DELETE /app/favorites/{dramaId}`、`POST /app/favorites/remove` |
-| 互动 | §1.7 | `GET/POST /app/comments`、`DELETE /app/comments/{id}`、`POST /app/likes/toggle`、`POST /app/reports` |
+| 下载 | `GET /app/downloads/policy`、`PUT /app/downloads/settings`、`POST/GET /app/downloads`、`GET /app/downloads/{id}/url`、`POST /app/downloads/{id}/progress`、`DELETE /app/downloads/{id}`、`DELETE /app/downloads` |
-| 公告 | §1.9.2 | `GET /app/notices` |
+| 互动 | `GET/POST /app/comments`、`DELETE /app/comments/{id}`、`GET /app/comments/count`、`POST /app/likes/toggle`、`POST /app/reports` |
+| 商业化 | `GET /app/wallet`、`/app/products`、`/app/orders` |
+| 公告 | `GET /app/notices` |
 
-客户端没有调用 `/app/config` 或创作者入驻接口。
+客户端没有调用 `/app/config` 和创作者入驻接口。
 
 ## 运行
 
@@ -66,39 +71,60 @@ flutter pub get
 ```bash
 adb devices
 adb reverse tcp:8081 tcp:8081
-flutter run -d <device> \
+flutter run -d <device>
-  --dart-define=API_BASE_URL=http://127.0.0.1:8081
 ```
 
 `adb reverse` 将手机的 `127.0.0.1:8081` 转发到电脑；USB 断开或重新连接后需要
-重新执行。
+重新执行。此时用调试条把地址改成 `http://127.0.0.1:8081`（见下节）。
 
-Android 模拟器访问宿主机时使用：
+Android 模拟器访问宿主机时，同样在调试条里填 `http://10.0.2.2:8081`。
-
-```bash
-flutter run --dart-define=API_BASE_URL=http://10.0.2.2:8081
-```
 
 ### iOS
 
-手机与 Mac 需在同一网络，首次启动允许“本地网络”权限：
+iOS 模拟器直接访问 Mac 本机服务，默认地址为 `http://127.0.0.1:8081`：
 
 ```bash
-flutter run -d <udid> \
+flutter run -d <simulator-udid>
-  --dart-define=API_BASE_URL=http://<Mac局域网IP>:8081
 ```
 
-### Debug 运行时地址
+iPhone 真机不能用 `127.0.0.1` 访问 Mac；真机联调时需让手机与 Mac 位于同一网络，
+并通过调试入口临时填写 Mac 的局域网地址。
 
-debug 版本可在「我的 → 设置 → 服务器地址」修改后端地址，保存后重启 App 生效。
+### 服务地址配置
-地址优先级：
 
-```text
+地址是代码里的一个开关，**不做任何网络探测**，也不用传构建参数。两套环境各占
-本地运行时设置 > --dart-define(API_BASE_URL) > 平台默认地址
+一个文件：
+
+| 文件 | 用途 | 默认值 |
+| --- | --- | --- |
+| `lib/core/config/dev_config.dart` | 开发 / 联调 | `http://127.0.0.1:8081` |
+| `lib/core/config/prod_config.dart` | 生产 | `http://39.162.50.99:8081` |
+
+切换环境只改 `lib/core/config/app_config.dart` 里的一个布尔值：
+
+```dart
+static const bool useDevConfig = true; // false 即用生产地址
 ```
 
-因此不带 `--dart-define` 构建的 debug APK 也可在安装后改成当前电脑 IP。
+真机或 Android 模拟器联调时，通过调试入口覆盖地址，不修改默认开发配置。打生产包前把
-release 版本不显示入口，也不会读取本地覆盖。
+`useDevConfig` 改成 `false`；release 构建若仍为 `true` 会在启动时直接报错，
+避免线上包连到开发机。
+
+debug 包在找剧页加载失败时会显示调试条，点「修改服务器地址」可临时改成当前
+电脑 IP，保存后立即重载、不需要重新打包，该覆盖保存在本地偏好里（仅 debug
+生效，release 不读取）。
+
+## 画中画
+
+| 平台 | 行为 |
+| --- | --- |
+| Android | 首次点播放页小窗按钮时申请悬浮窗权限；授权后退出 App 自动进入系统小窗。沉浸流与独立播放页共用一份引用计数，任一处活跃都算「在播」，避免互相顶掉 |
+| iOS | 原生影子播放器承载 `AVPictureInPictureController`，只有播放页处于活跃状态时退到后台才自动进小窗；停在剧单等页面退后台不会触发 |
+
+- 小窗内切集直接换源，不走页面翻页，可连续自动播放
+- iOS 从系统小窗还原时用原生过渡层盖住纹理黑帧，等首帧就绪后再淡出
+- 播放页「更多」面板里有「退出自动小窗」开关（仅支持自动小窗的平台显示），关掉后
+  退到后台不再进入小窗
 
 ## 环境注意
 
@@ -131,46 +157,56 @@ xcodebuild -resolvePackageDependencies \
 
 ```bash
 adb uninstall com.stormg.lumadrama
-flutter run -d <device> \
+flutter run -d <device>
-  --dart-define=API_BASE_URL=http://127.0.0.1:8081
 ```
 
 ## 生产打包（Android）
 
-生产包只包含以下两个 ABI，**打成一个 APK**，不做 split：
+两个渠道出两种产物，源码同一套：
 
-| ABI | 适用设备 |
+| 渠道 | 产物 | 命令 | 体积 |
-| --- | --- |
+| --- | --- | --- | --- |
-| `arm64-v8a` | 现代手机（64 位） |
+| Google Play | AAB（按设备下发） | `flutter build appbundle --release` | 上传 28MB，用户下载约 8MB |
-| `armeabi-v7a` | 老 32 位机 |
+| 国内各大市场 | 通用 APK（arm64 + v7） | `flutter build apk --release` | 约 13MB |
-
-```bash
-flutter build apk --release --target-platform android-arm64,android-arm
-# 产出单个：build/app/outputs/flutter-apk/app-release.apk（约 37MB）
-```
 
 说明：
 
 - `android/app/build.gradle.kts` 的 `release` 已配置 `abiFilters`，只保留 `arm64-v8a` 与 `armeabi-v7a`，插件也不会再带入 `x86_64` 原生库。
-- `x86_64` 只用于模拟器，不进入生产包。
+- `android/gradle.properties` 里固定了 `split-debug-info=build/symbols` 与 `dart-obfuscation=true`，**IDE 里点 Build APK / Build App Bundle 也会生效**：`libapp.so` 从 ~8MB/ABI 降到 ~1.1MB/ABI。
-- 不要直接运行 `flutter build apk --release`：默认会编译三套原生库，包体约 57MB。
+- `useLegacyPackaging = true`：原生库以压缩形式存储，这是国内 APK 从 40MB 降到 13MB 的主要原因；代价是安装时解压。
-- 只有需要进一步压缩单机下载体积时，才考虑 `--split-per-abi` 出分架构包（arm64 约 21MB、armv7 约 19MB），默认不用。
+- **每次发版都要归档 `build/symbols`**，线上崩溃栈需要它还原。
+- release 仍在用 debug 签名（`build.gradle.kts` 的 TODO），上架前必须换成正式 keystore。
+- 不要用 `--split-per-abi`：与 `abiFilters` 冲突；Play 的 AAB 已经按设备拆好。
+
+## 生产打包（iOS）
+
+```bash
+# 正式签名（需要 iOS Distribution 证书 + App Store 描述文件）
+flutter build ipa --release
+
+# 只有 Apple Development 证书时：出开发签名 IPA，只能装已注册设备
+flutter build ipa --release --export-method development
+```
+
+产物在 `build/ios/ipa/*.ipa`。画中画依赖 `UIBackgroundModes` 里的 `audio` 与
+`AVPictureInPictureController`，改动 `ios/Runner/Info.plist` 或 `AppDelegate.swift`
+后要重新构建，热重载不会生效。
 
 ## 门禁
 
 ```bash
-dart analyze lib test
+dart analyze
 flutter test
 flutter build apk --debug
 ```
 
-测试文件按模块放在 `test/` 下，用例名使用
+当前基线：`dart analyze` 仅 1 条既存 info（`intl` 未在 `pubspec.yaml` 声明)；
+`flutter test` 全量 775 例通过。测试文件按模块放在 `test/` 下，用例名使用
 `should_<期望>_when_<条件>`。真实后端联调测试在服务未启动时会跳过。
 
 ## 当前边界
 
-- 下载仅管理服务端授权，不落盘、不续传、不支持离线播放。
+- 下载会落盘并支持离线播放，但不支持断点续传：中途失败会丢弃 `.part` 重下。
-- 没有独立搜索接口，搜索能力尚未形成完整闭环。
+- 支付与金币：客户端已有钱包、商品、下单接口与页面，商店票据校验依赖服务端配置凭据。
 - 站内通知没有已读/未读和红点状态。
-- 支付、金币和会员权益尚未形成客户端闭环。
+- 播放清晰度切换会保留旧画面 500ms 掩盖闪屏，切换瞬间的进度以相对位置续播。
-- Android 支持系统画中画；iOS 画中画尚未接入。

android/.gitignore

@@ -1,4 +1,5 @@
 /.gradle
+/build/
 /captures/
 /local.properties
 GeneratedPluginRegistrant.java

android/app/build.gradle.kts

@@ -8,7 +8,9 @@ plugins {
 
 android {
     namespace = "com.stormg.lumadrama"
-    compileSdk = flutter.compileSdkVersion
+    // permission_handler_android 14 的 AAR 元数据要求依赖方 compileSdk >= 37，
+    // 固定为 37（比 Flutter 默认的 36 高一档，只影响编译期 API 可见性）。
+    compileSdk = 37
     ndkVersion = flutter.ndkVersion
 
     compileOptions {
@@ -33,6 +35,13 @@ android {
             ndk {
                 abiFilters += listOf("arm64-v8a", "armeabi-v7a")
             }
+            // R8 裁剪未使用的 Java/Kotlin 代码与资源，减小 dex 与 res。
+            isMinifyEnabled = true
+            isShrinkResources = true
+            proguardFiles(
+                getDefaultProguardFile("proguard-android-optimize.txt"),
+                "proguard-rules.pro",
+            )
             // TODO: Add your own signing config for the release build.
             // Signing with the debug keys for now, so `flutter run --release` works.
             signingConfig = signingConfigs.getByName("debug")
@@ -50,6 +59,9 @@ kotlin {
 androidComponents {
     onVariants(selector().withBuildType("release")) { variant ->
         variant.packaging.jniLibs.excludes.add("lib/x86_64/**")
+        // 原生库随 APK 压缩存储：下载体积明显小于解压后的体积，代价是安装时解压。
+        // 本包 90% 体积是 so，这一项对国内商店的 APK 分发影响最大。
+        variant.packaging.jniLibs.useLegacyPackaging = true
     }
 }
 

android/app/proguard-rules.pro

@@ -0,0 +1,11 @@
+# Author: fruit.com.cn
+#
+# R8 保号规则：Flutter 引擎与插件自带的 consumer rules 已覆盖大部分场景，
+# 这里只补本项目原生层通过反射/通道访问、裁剪后容易失效的入口。
+
+# 画中画与权限通道由 MainActivity 直接注册，保留应用包名下的入口类。
+-keep class com.stormg.lumadrama.** { *; }
+
+# Flutter 引擎在 release 下通过 JNI 回调这些类，禁止改名。
+-keep class io.flutter.** { *; }
+-dontwarn io.flutter.embedding.**

android/app/src/main/AndroidManifest.xml

@@ -2,8 +2,11 @@
 <manifest xmlns:android="http://schemas.android.com/apk/res/android">
     <uses-permission
         android:name="android.permission.INTERNET"/>
+    <!-- 画中画自动触发依赖的「显示在其他应用上层」权限（部分 ROM 用它管控 PiP） -->
+    <uses-permission
+        android:name="android.permission.SYSTEM_ALERT_WINDOW"/>
     <application
-        android:label="FruitShorts"
+        android:label="ymb"
         android:name="${applicationName}"
         android:icon="@mipmap/ic_launcher"
         android:usesCleartextTraffic="true">

android/app/src/main/kotlin/com/stormg/lumadrama/MainActivity.kt

@@ -284,6 +284,7 @@ class MainActivity : FlutterActivity() {
     }
 
     companion object {
+        private const val TAG = "FruitPip"
         private const val thumbnailMaxWidth = 240
         private const val thumbnailJpegQuality = 70
         private const val thumbnailTimeoutMs = 1500L

android/app/src/main/res/values-night-v31/styles.xml

@@ -8,7 +8,7 @@
         <item name="android:windowDrawsSystemBarBackgrounds">false</item>
         <item name="android:windowLayoutInDisplayCutoutMode">shortEdges</item>
         <item name="android:windowSplashScreenBackground">#000000</item>
-        <item name="android:windowSplashScreenAnimatedIcon">@drawable/splash_brand</item>
+        <item name="android:windowSplashScreenAnimatedIcon">@drawable/android12splash</item>
         <item name="android:windowSplashScreenAnimationDuration">0</item>
     </style>
     <style name="NormalTheme" parent="@android:style/Theme.Black.NoTitleBar">

android/app/src/main/res/values-v31/styles.xml

@@ -8,7 +8,7 @@
         <item name="android:windowDrawsSystemBarBackgrounds">false</item>
         <item name="android:windowLayoutInDisplayCutoutMode">shortEdges</item>
         <item name="android:windowSplashScreenBackground">#000000</item>
-        <item name="android:windowSplashScreenAnimatedIcon">@drawable/splash_brand</item>
+        <item name="android:windowSplashScreenAnimatedIcon">@drawable/android12splash</item>
         <item name="android:windowSplashScreenAnimationDuration">0</item>
     </style>
     <style name="NormalTheme" parent="@android:style/Theme.Light.NoTitleBar">

android/app/src/main/res/values/colors.xml

@@ -3,5 +3,5 @@
 
 <resources>
 	<color name="splash_background">#000000</color>
-	<color name="ic_launcher_background">#FF6B2C</color>
+	<color name="ic_launcher_background">#000000</color>
 </resources>

android/gradle.properties

@@ -6,3 +6,8 @@ android.useAndroidX=true
 android.newDsl=false
 # This builtInKotlin flag was added by the Flutter template
 android.builtInKotlin=false
+
+# release 包默认剥离 Dart 调试符号并混淆：libapp.so 由 ~8MB 降到 ~1MB/ABI。
+# 符号表输出到 build/symbols，崩溃分析时用它还原堆栈，发布前务必归档。
+split-debug-info=build/symbols
+dart-obfuscation=true

ios/Runner.xcodeproj/project.pbxproj

@@ -387,7 +387,7 @@
 					"$(inherited)",
 					"@executable_path/Frameworks",
 				);
-				PRODUCT_BUNDLE_IDENTIFIER = com.stormg.lumadramv;
+				PRODUCT_BUNDLE_IDENTIFIER = com.stormg.lumadrama;
 				PRODUCT_NAME = "$(TARGET_NAME)";
 				SWIFT_OBJC_BRIDGING_HEADER = "Runner/Runner-Bridging-Header.h";
 				SWIFT_VERSION = 5.0;
@@ -567,7 +567,7 @@
 					"$(inherited)",
 					"@executable_path/Frameworks",
 				);
-				PRODUCT_BUNDLE_IDENTIFIER = com.stormg.lumadramv;
+				PRODUCT_BUNDLE_IDENTIFIER = com.stormg.lumadrama;
 				PRODUCT_NAME = "$(TARGET_NAME)";
 				SWIFT_OBJC_BRIDGING_HEADER = "Runner/Runner-Bridging-Header.h";
 				SWIFT_OPTIMIZATION_LEVEL = "-Onone";
@@ -590,7 +590,7 @@
 					"$(inherited)",
 					"@executable_path/Frameworks",
 				);
-				PRODUCT_BUNDLE_IDENTIFIER = com.stormg.lumadramv;
+				PRODUCT_BUNDLE_IDENTIFIER = com.stormg.lumadrama;
 				PRODUCT_NAME = "$(TARGET_NAME)";
 				SWIFT_OBJC_BRIDGING_HEADER = "Runner/Runner-Bridging-Header.h";
 				SWIFT_VERSION = 5.0;

ios/Runner.xcworkspace/xcshareddata/swiftpm/Package.resolved

@@ -0,0 +1,68 @@
+{
+  "pins" : [
+    {
+      "identity" : "app-check",
+      "kind" : "remoteSourceControl",
+      "location" : "https://github.com/google/app-check.git",
+      "state" : {
+        "revision" : "b7c71458b70284cc0f5a87103f66f0b1d98b1873",
+        "version" : "12.1.0"
+      }
+    },
+    {
+      "identity" : "appauth-ios",
+      "kind" : "remoteSourceControl",
+      "location" : "https://github.com/openid/AppAuth-iOS.git",
+      "state" : {
+        "revision" : "a972daac82d449d58ab119e91c68153e29ddac33",
+        "version" : "3.0.0"
+      }
+    },
+    {
+      "identity" : "googlesignin-ios",
+      "kind" : "remoteSourceControl",
+      "location" : "https://github.com/google/GoogleSignIn-iOS.git",
+      "state" : {
+        "revision" : "bfaebbc04a4d13ed7a89b0fc1fb8ad66b362cc1c",
+        "version" : "10.1.0"
+      }
+    },
+    {
+      "identity" : "googleutilities",
+      "kind" : "remoteSourceControl",
+      "location" : "https://github.com/google/GoogleUtilities.git",
+      "state" : {
+        "revision" : "5459ee5603def3db0fe14ca522185f42c48d978e",
+        "version" : "8.1.5"
+      }
+    },
+    {
+      "identity" : "gtm-session-fetcher",
+      "kind" : "remoteSourceControl",
+      "location" : "https://github.com/google/gtm-session-fetcher.git",
+      "state" : {
+        "revision" : "724a52eea6329b7e12d3ad8300d76ca9f3895fcc",
+        "version" : "5.3.1"
+      }
+    },
+    {
+      "identity" : "gtmappauth",
+      "kind" : "remoteSourceControl",
+      "location" : "https://github.com/google/GTMAppAuth.git",
+      "state" : {
+        "revision" : "57094cd46bc8700d3a887e2a429f42b6e8ea3f0b",
+        "version" : "6.0.0"
+      }
+    },
+    {
+      "identity" : "interop-ios-for-google-sdks",
+      "kind" : "remoteSourceControl",
+      "location" : "https://github.com/google/interop-ios-for-google-sdks.git",
+      "state" : {
+        "revision" : "040d087ac2267d2ddd4cca36c757d1c6a05fdbfe",
+        "version" : "101.0.0"
+      }
+    }
+  ],
+  "version" : 2
+}

ios/Runner/AppDelegate.swift

@@ -1,6 +1,7 @@
 import Flutter
 import UIKit
 import AVFoundation
+import AVKit
 
 private let thumbnailHTTPHeaderFieldsKey = "AVURLAssetHTTPHeaderFieldsKey"
 
@@ -35,6 +36,318 @@ final class RunnerFlutterViewController: FlutterViewController {
   }
 }
 
+/// iOS 影子播放器：独立 AVPlayer + AVPlayerLayer 专供画中画窗口。
+/// Flutter 的 video_player 走纹理渲染，没有 AVPlayerLayer，无法直接创建
+/// AVPictureInPictureController；小窗的画面与声音由影子接管，退出时把
+/// 影子进度回传给 Dart，由 Flutter 播放器 seek 对齐后继续。
+final class PipShadowCoordinator: NSObject, AVPictureInPictureControllerDelegate {
+  static let shared = PipShadowCoordinator()
+
+  private var player: AVPlayer?
+  private var playerLayer: AVPlayerLayer?
+  private var controller: AVPictureInPictureController?
+  private var endObserver: NSObjectProtocol?
+  private var possibleObservation: NSKeyValueObservation?
+  /// 画中画还原过渡层：原生窗口级红晕渐变，在系统还原动画开始时立即盖上，
+  /// 避免回前台瞬间 Flutter 表面未恢复显示黑帧；视频出帧后由 Dart 通知淡出。
+  private var restoreOverlay: UIView?
+  /// 系统要求 playerLayer 位于真实的 view 层级中才会判定画中画可用，
+  /// 因此用 1x1 透明宿主 view 承载，而不是直接挂在 window.layer 上。
+  private var hostView: UIView?
+  /// 影子图层就绪稍晚于创建，置位后由 KVO 自动拉起画中画。
+  private var pendingStart = false
+  private var startRetryWorkItems: [DispatchWorkItem] = []
+
+  weak var channel: FlutterMethodChannel?
+
+  /// active 变化回调；停止时把影子最终进度（毫秒）一并提供。
+  var onPipChanged: ((Bool, Int64) -> Void)?
+  /// 影子在画中画里播完当前集。
+  var onPlaybackEnded: (() -> Void)?
+
+  static var isSupported: Bool {
+    AVPictureInPictureController.isPictureInPictureSupported()
+  }
+
+  private var keyWindow: UIWindow? {
+    UIApplication.shared.connectedScenes
+      .compactMap { $0 as? UIWindowScene }
+      .flatMap { $0.windows }
+      .first { $0.isKeyWindow }
+  }
+
+  /// 首次创建影子：1x1 图层挂在 keyWindow 的宿主 view 里（肉眼不可见），静音待命。
+  /// [autoEnter] 为 true 时退后台由系统自动拉起画中画（需影子在播，见 armAutoEnter）。
+  func prepare(urlString: String, positionMs: Int64, autoEnter: Bool) {
+    teardown()
+    log("prepare begin supported=\(PipShadowCoordinator.isSupported) autoEnter=\(autoEnter)")
+    guard Self.isSupported else { return }
+    guard let url = URL(string: urlString) else {
+      log("prepare failed bad url \(urlString)")
+      return
+    }
+    guard let window = keyWindow else {
+      log("prepare failed no key window")
+      return
+    }
+    let item = AVPlayerItem(url: url)
+    let p = AVPlayer(playerItem: item)
+    p.isMuted = true
+    p.actionAtItemEnd = .pause
+    let layer = AVPlayerLayer()
+    layer.player = p
+    let host = UIView(frame: CGRect(x: 0, y: 0, width: 1, height: 1))
+    host.isUserInteractionEnabled = false
+    host.backgroundColor = .clear
+    window.addSubview(host)
+    layer.frame = host.bounds
+    host.layer.addSublayer(layer)
+    hostView = host
+    guard let c = AVPictureInPictureController(playerLayer: layer) else {
+      p.pause()
+      log("prepare failed no pip controller")
+      return
+    }
+    c.canStartPictureInPictureAutomaticallyFromInline = autoEnter
+    c.delegate = self
+    player = p
+    playerLayer = layer
+    controller = c
+    // 静音起播让 item 完成首帧解码，isPictureInPicturePossible 才会变 true。
+    p.play()
+    possibleObservation = c.observe(
+      \.isPictureInPicturePossible,
+      options: [.new, .initial]
+    ) { [weak self] controller, change in
+      let value = change.newValue ?? controller.isPictureInPicturePossible
+      self?.log("possible changed to \(value)")
+      guard let self, self.pendingStart, controller.isPictureInPicturePossible else { return }
+      self.pendingStart = false
+      // 刚翻 true 的同一 runloop 里调用会被系统静默拒绝，推到下一拍再进。
+      DispatchQueue.main.async {
+        guard self.controller === controller, controller.isPictureInPicturePossible else {
+          self.log("start via kvo aborted (shadow replaced)")
+          return
+        }
+        self.log("start via kvo")
+        controller.startPictureInPicture()
+      }
+    }
+    log("shadow ready, seeking to \(positionMs)ms")
+    if positionMs > 0 {
+      p.seek(
+        to: CMTime(value: positionMs, timescale: 1000),
+        toleranceBefore: .zero,
+        toleranceAfter: .zero
+      )
+    }
+    registerEndObserver(for: item)
+    activateAudioSession()
+  }
+
+  /// 退出 App 前（inactive）把影子对齐到当前进度并静音起播：
+  /// auto PiP 只在「player 正在播放 + 图层离屏」时由系统触发。
+  func armAutoEnter(positionMs: Int64) {
+    guard let player, let controller else {
+      log("arm failed, shadow missing")
+      return
+    }
+    guard controller.canStartPictureInPictureAutomaticallyFromInline else {
+      log("arm failed, autoEnter disabled on shadow")
+      return
+    }
+    log("arm auto enter at \(positionMs)ms")
+    if positionMs > 0 {
+      player.seek(
+        to: CMTime(value: positionMs, timescale: 1000),
+        toleranceBefore: CMTime(value: 800, timescale: 1000),
+        toleranceAfter: CMTime(value: 800, timescale: 1000)
+      )
+    }
+    player.play()
+  }
+
+  /// 回前台后取消待命：影子暂停回静音，等待下一次退后台。
+  func disarmAutoEnter() {
+    guard let player else { return }
+    log("disarm auto enter")
+    player.pause()
+    player.isMuted = true
+  }
+
+  /// 进入画中画：图层就绪则立即进入，否则 KVO/延时重试在就绪后自动进入。
+  /// 仅当影子从未创建成功（prepare 失败）时返回 false。
+  func start() -> Bool {
+    guard let controller else {
+      log("start failed, shadow not created")
+      return false
+    }
+    log("start requested possible=\(controller.isPictureInPicturePossible)")
+    pendingStart = true
+    if controller.isPictureInPicturePossible {
+      pendingStart = false
+      controller.startPictureInPicture()
+    }
+    scheduleStartRetries()
+    return true
+  }
+
+  /// KVO 偶发不触发或流加载较慢时兜底：就绪后再试两次。
+  private func scheduleStartRetries() {
+    startRetryWorkItems.forEach { $0.cancel() }
+    startRetryWorkItems.removeAll()
+    for delay in [1.0, 2.5] {
+      let item = DispatchWorkItem { [weak self] in
+        guard
+            let self,
+            self.pendingStart,
+            let controller = self.controller,
+            controller.isPictureInPicturePossible
+        else { return }
+        self.log("start via retry after \(delay)s")
+        self.pendingStart = false
+        controller.startPictureInPicture()
+      }
+      startRetryWorkItems.append(item)
+      DispatchQueue.main.asyncAfter(deadline: .now() + delay, execute: item)
+    }
+  }
+
+  /// 画中画内换集：只换 AVPlayerItem，不动 player/layer，窗口不中断。
+  func replaceItem(urlString: String, positionMs: Int64) {
+    guard let player, let url = URL(string: urlString) else { return }
+    let item = AVPlayerItem(url: url)
+    player.replaceCurrentItem(with: item)
+    registerEndObserver(for: item)
+    if positionMs > 0 {
+      player.seek(
+        to: CMTime(value: positionMs, timescale: 1000),
+        toleranceBefore: .zero,
+        toleranceAfter: .zero
+      )
+    }
+  }
+
+  /// 进入画中画后解除静音并起播（此时 Flutter 播放器已被暂停）。
+  func unmuteAndPlay() {
+    player?.isMuted = false
+    player?.play()
+  }
+
+  func positionMs() -> Int64 {
+    Int64(max(0, player?.currentTime().seconds ?? 0) * 1000)
+  }
+
+  func stopPip() {
+    controller?.stopPictureInPicture()
+  }
+
+  func teardown() {
+    startRetryWorkItems.forEach { $0.cancel() }
+    startRetryWorkItems.removeAll()
+    possibleObservation?.invalidate()
+    possibleObservation = nil
+    pendingStart = false
+    if let endObserver {
+      NotificationCenter.default.removeObserver(endObserver)
+    }
+    endObserver = nil
+    player?.pause()
+    player?.replaceCurrentItem(with: nil)
+    playerLayer?.removeFromSuperlayer()
+    playerLayer = nil
+    hostView?.removeFromSuperview()
+    hostView = nil
+    controller?.delegate = nil
+    controller = nil
+    player = nil
+  }
+
+  /// 诊断日志：NSLog 之外同步转发到 Dart，便于在 flutter run 控制台观察。
+  private func log(_ message: String) {
+    NSLog("pip: %@", message)
+    channel?.invokeMethod("pipDebug", arguments: message)
+  }
+
+  private func registerEndObserver(for item: AVPlayerItem) {
+    if let endObserver {
+      NotificationCenter.default.removeObserver(endObserver)
+    }
+    endObserver = NotificationCenter.default.addObserver(
+      forName: .AVPlayerItemDidPlayToEndTime,
+      object: item,
+      queue: .main
+    ) { [weak self] _ in
+      self?.log("item did play to end")
+      self?.onPlaybackEnded?()
+    }
+  }
+
+  /// 画中画的声音走影子播放器，需要 playback 类别的音频会话保活。
+  private func activateAudioSession() {
+    do {
+      try AVAudioSession.sharedInstance().setCategory(.playback, mode: .moviePlayback)
+      try AVAudioSession.sharedInstance().setActive(true)
+    } catch {
+      // 会话激活失败只影响后台出声，不阻断画中画。
+    }
+  }
+
+  func pictureInPictureControllerWillStartPictureInPicture(
+    _ pictureInPictureController: AVPictureInPictureController
+  ) {
+    log("will start")
+    pendingStart = false
+    onPipChanged?(true, 0)
+  }
+
+  func pictureInPictureControllerWillStopPictureInPicture(
+    _ pictureInPictureController: AVPictureInPictureController
+  ) {
+    log("will stop, showing restore overlay")
+    showRestoreOverlay()
+  }
+
+  func pictureInPictureControllerDidStopPictureInPicture(
+    _ pictureInPictureController: AVPictureInPictureController
+  ) {
+    log("did stop")
+    showRestoreOverlay()
+    onPipChanged?(false, positionMs())
+  }
+
+  /// 盖原生过渡层（幂等）：主题红晕渐变，不依赖 Flutter 渲染。
+  func showRestoreOverlay() {
+    guard let window = keyWindow else { return }
+    restoreOverlay?.removeFromSuperview()
+    let overlay = UIView(frame: window.bounds)
+    overlay.autoresizingMask = [.flexibleWidth, .flexibleHeight]
+    let gradient = CAGradientLayer()
+    gradient.frame = overlay.bounds
+    gradient.colors = [
+      UIColor(red: 0.298, green: 0.086, blue: 0.102, alpha: 1).cgColor,
+      UIColor(red: 0.118, green: 0.043, blue: 0.047, alpha: 1).cgColor,
+      UIColor(red: 0.063, green: 0.063, blue: 0.071, alpha: 1).cgColor,
+    ]
+    gradient.locations = [0, 0.22, 0.62]
+    gradient.startPoint = CGPoint(x: 0.5, y: 0)
+    gradient.endPoint = CGPoint(x: 0.5, y: 1)
+    overlay.layer.addSublayer(gradient)
+    window.addSubview(overlay)
+    restoreOverlay = overlay
+  }
+
+  /// 淡出并移除过渡层（视频首帧已确认后由 Dart 调用）。
+  func hideRestoreOverlay() {
+    guard let overlay = restoreOverlay else { return }
+    restoreOverlay = nil
+    UIView.animate(
+      withDuration: 0.25,
+      animations: { overlay.alpha = 0 }
+    ) { _ in overlay.removeFromSuperview() }
+  }
+}
+
 @main
 @objc class AppDelegate: FlutterAppDelegate, FlutterImplicitEngineDelegate {
   private let wirelessDataPrompt = WirelessDataPrompt()
@@ -64,6 +377,7 @@ final class RunnerFlutterViewController: FlutterViewController {
     GeneratedPluginRegistrant.register(with: engineBridge.pluginRegistry)
     registerWirelessDataChannel(engineBridge)
     registerDeviceIdChannel(engineBridge)
+    registerPipChannel(engineBridge)
     let channel = FlutterMethodChannel(
       name: "com.stormg.lumadrama/share",
       binaryMessenger: engineBridge.applicationRegistrar.messenger()
@@ -72,16 +386,30 @@ final class RunnerFlutterViewController: FlutterViewController {
       guard call.method == "shareText",
             let arguments = call.arguments as? [String: Any],
             let text = arguments["text"] as? String,
-            !text.isEmpty,
+            !text.isEmpty else {
-            let controller = self?.window?.rootViewController else {
+        result(FlutterError(code: "share_unavailable", message: "Share sheet is unavailable", details: nil))
+        return
+      }
+      DispatchQueue.main.async {
+        guard let controller = self?.sharePresenter() else {
           result(FlutterError(code: "share_unavailable", message: "Share sheet is unavailable", details: nil))
           return
         }
         let activity = UIActivityViewController(activityItems: [text], applicationActivities: nil)
-      activity.popoverPresentationController?.sourceView = controller.view
+        if let popover = activity.popoverPresentationController {
+          popover.sourceView = controller.view
+          popover.sourceRect = CGRect(
+            x: controller.view.bounds.midX,
+            y: controller.view.bounds.midY,
+            width: 0,
+            height: 0
+          )
+          popover.permittedArrowDirections = []
+        }
         activity.completionWithItemsHandler = { _, _, _, _ in result(nil) }
         controller.present(activity, animated: true)
       }
+    }
 
     let thumbnailChannel = FlutterMethodChannel(
       name: "com.stormg.lumadrama/thumbnail",
@@ -145,6 +473,119 @@ final class RunnerFlutterViewController: FlutterViewController {
     }
   }
 
+  /// 当前前台 Scene 的根控制器之上，最适合展示系统分享面板的控制器。
+  private func sharePresenter() -> UIViewController? {
+    let keyWindow = UIApplication.shared.connectedScenes
+      .compactMap { $0 as? UIWindowScene }
+      .first { $0.activationState == .foregroundActive }?
+      .windows.first { $0.isKeyWindow }
+    guard let rootController = keyWindow?.rootViewController else { return nil }
+    let presenter = topPresentedController(from: rootController)
+    guard presenter.viewIfLoaded?.window != nil else { return nil }
+    return presenter
+  }
+
+  /// 解析已展示页面、导航栈和标签页中的当前可见控制器。
+  private func topPresentedController(from controller: UIViewController) -> UIViewController {
+    if let presented = controller.presentedViewController {
+      return topPresentedController(from: presented)
+    }
+    if let navigation = controller as? UINavigationController,
+       let visible = navigation.visibleViewController {
+      return topPresentedController(from: visible)
+    }
+    if let tabs = controller as? UITabBarController,
+       let selected = tabs.selectedViewController {
+      return topPresentedController(from: selected)
+    }
+    return controller
+  }
+
+  /// iOS 画中画：影子播放器通道，与 Android 共用同一 channel 名。
+  private func registerPipChannel(_ engineBridge: FlutterImplicitEngineBridge) {
+    let channel = FlutterMethodChannel(
+      name: "com.stormg.lumadrama/pip",
+      binaryMessenger: engineBridge.applicationRegistrar.messenger()
+    )
+    let pip = PipShadowCoordinator.shared
+    pip.channel = channel
+    channel.setMethodCallHandler { call, result in
+      switch call.method {
+      case "isAvailable":
+        result(PipShadowCoordinator.isSupported)
+      case "enter":
+        guard let args = call.arguments as? [String: Any],
+              let url = args["url"] as? String else {
+          result(false)
+          return
+        }
+        let positionMs = (args["positionMs"] as? NSNumber)?.int64Value ?? 0
+        pip.prepare(urlString: url, positionMs: positionMs, autoEnter: false)
+        // 等一拍让 AVPlayerLayer 完成挂载再请求进入画中画。
+        DispatchQueue.main.async {
+          result(pip.start())
+        }
+      case "prepareShadow":
+        guard let args = call.arguments as? [String: Any],
+              let url = args["url"] as? String else {
+          result(nil)
+          return
+        }
+        pip.prepare(
+          urlString: url,
+          positionMs: (args["positionMs"] as? NSNumber)?.int64Value ?? 0,
+          autoEnter: (args["autoEnter"] as? NSNumber)?.boolValue ?? false
+        )
+        result(nil)
+      case "armAutoEnter":
+        pip.armAutoEnter(
+          positionMs: (call.arguments as? [String: Any])?["positionMs"] as? Int64 ?? 0
+        )
+        result(nil)
+      case "showRestoreOverlay":
+        pip.showRestoreOverlay()
+        result(nil)
+      case "hideRestoreOverlay":
+        pip.hideRestoreOverlay()
+        result(nil)
+      case "disarmAutoEnter":
+        pip.disarmAutoEnter()
+        result(nil)
+      case "unmute":
+        pip.unmuteAndPlay()
+        result(nil)
+      case "replaceItem":
+        guard let args = call.arguments as? [String: Any],
+              let url = args["url"] as? String else {
+          result(nil)
+          return
+        }
+        pip.replaceItem(
+          urlString: url,
+          positionMs: (args["positionMs"] as? NSNumber)?.int64Value ?? 0
+        )
+        result(nil)
+      case "stop":
+        pip.stopPip()
+        result(nil)
+      case "teardown":
+        pip.teardown()
+        result(nil)
+      default:
+        result(FlutterMethodNotImplemented)
+      }
+    }
+    pip.onPipChanged = { active, positionMs in
+      channel.invokeMethod(
+        "onPipChanged",
+        arguments: ["active": active, "positionMs": positionMs]
+      )
+    }
+    pip.onPlaybackEnded = {
+      channel.invokeMethod("onPipPlaybackEnded", arguments: nil)
+    }
+  }
+
   /// 设备标识：IDFV 免权限，卸载本 App 不变，避免客户端自生成的 id 每次重装都变。
   /// 同通道顺带提供设备区域（ISO-2），注册时作为服务端 IP 解析失败后的兜底。
   private func registerDeviceIdChannel(_ engineBridge: FlutterImplicitEngineBridge) {

ios/Runner/Info.plist

@@ -1,13 +1,13 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE plist PUBLIC "-//Apple//DTD PLIST 1.0//EN" "http://www.apple.com/DTDs/PropertyList-1.0.dtd">
 <plist version="1.0">
-	<dict>
+<dict>
 	<key>CADisableMinimumFrameDurationOnPhone</key>
 	<true/>
 	<key>CFBundleDevelopmentRegion</key>
 	<string>$(DEVELOPMENT_LANGUAGE)</string>
 	<key>CFBundleDisplayName</key>
-		<string>FruitShorts</string>
+	<string>ymb</string>
 	<key>CFBundleExecutable</key>
 	<string>$(EXECUTABLE_NAME)</string>
 	<key>CFBundleIdentifier</key>
@@ -15,7 +15,7 @@
 	<key>CFBundleInfoDictionaryVersion</key>
 	<string>6.0</string>
 	<key>CFBundleName</key>
-		<string>FruitShorts</string>
+	<string>ymb</string>
 	<key>CFBundlePackageType</key>
 	<string>APPL</string>
 	<key>CFBundleShortVersionString</key>
@@ -24,6 +24,19 @@
 	<string>????</string>
 	<key>CFBundleVersion</key>
 	<string>$(FLUTTER_BUILD_NUMBER)</string>
+	<key>CFBundleURLTypes</key>
+	<array>
+		<dict>
+			<key>CFBundleTypeRole</key>
+			<string>Editor</string>
+			<key>CFBundleURLSchemes</key>
+			<array>
+				<string>com.googleusercontent.apps.11115008580-51gv4sj2c78rud6n127g3shu4d2n96un</string>
+			</array>
+		</dict>
+	</array>
+	<key>GIDClientID</key>
+	<string>11115008580-51gv4sj2c78rud6n127g3shu4d2n96un.apps.googleusercontent.com</string>
 	<key>LSRequiresIPhoneOS</key>
 	<true/>
 	<key>NSAppTransportSecurity</key>
@@ -41,13 +54,6 @@
 				<key>NSIncludesSubdomains</key>
 				<true/>
 			</dict>
-				<key>localhost</key>
-				<dict>
-					<key>NSExceptionAllowsInsecureHTTPLoads</key>
-					<true/>
-					<key>NSIncludesSubdomains</key>
-					<true/>
-				</dict>
 			<key>192.168.31.243</key>
 			<dict>
 				<key>NSExceptionAllowsInsecureHTTPLoads</key>
@@ -62,6 +68,13 @@
 				<key>NSIncludesSubdomains</key>
 				<true/>
 			</dict>
+			<key>localhost</key>
+			<dict>
+				<key>NSExceptionAllowsInsecureHTTPLoads</key>
+				<true/>
+				<key>NSIncludesSubdomains</key>
+				<true/>
+			</dict>
 		</dict>
 	</dict>
 	<key>NSLocalNetworkUsageDescription</key>
@@ -89,10 +102,16 @@
 	</dict>
 	<key>UIApplicationSupportsIndirectInputEvents</key>
 	<true/>
+	<key>UIBackgroundModes</key>
+	<array>
+		<string>audio</string>
+	</array>
 	<key>UILaunchStoryboardName</key>
 	<string>LaunchScreen</string>
 	<key>UIMainStoryboardFile</key>
 	<string>Main</string>
+	<key>UIStatusBarHidden</key>
+	<false/>
 	<key>UISupportedInterfaceOrientations</key>
 	<array>
 		<string>UIInterfaceOrientationPortrait</string>
@@ -105,7 +124,5 @@
 		<string>UIInterfaceOrientationLandscapeLeft</string>
 		<string>UIInterfaceOrientationLandscapeRight</string>
 	</array>
-		<key>UIStatusBarHidden</key>
+</dict>
-		<false/>
-	</dict>
 </plist>

lib/app.dart

@@ -14,12 +14,14 @@ import 'core/data/remote/catalog_api.dart';
 import 'core/data/remote/category_api.dart';
 import 'core/data/remote/comment_api.dart';
 import 'core/data/remote/commerce_api.dart';
+import 'core/data/remote/config_api.dart';
 import 'core/data/remote/device_profile.dart';
 import 'core/data/remote/download_api.dart';
 import 'core/data/remote/interaction_api.dart';
 import 'core/data/remote/library_api.dart';
 import 'core/data/remote/notice_api.dart';
 import 'core/data/remote/playback_api.dart';
+import 'core/data/remote/reward_api.dart';
 import 'core/data/remote/watch_api.dart';
 import 'core/data/repositories/catalog_repository.dart';
 import 'core/data/repositories/account_repository.dart';
@@ -32,9 +34,11 @@ import 'core/data/repositories/interaction_repository.dart';
 import 'core/data/repositories/notice_repository.dart';
 import 'core/data/repositories/playback_repository.dart';
 import 'core/data/repositories/playlist_repository.dart';
+import 'core/data/repositories/reward_repository.dart';
 import 'core/data/repositories/search_repository.dart';
 import 'core/data/repositories/store_repository.dart';
 import 'core/data/repositories/watch_history_repository.dart';
+import 'core/data/services/app_config_controller.dart';
 import 'core/data/services/auth_controller.dart';
 import 'core/data/services/auth_session_store.dart';
 import 'core/data/services/catalog_controller.dart';
@@ -47,6 +51,8 @@ import 'core/data/services/playlist_controller.dart';
 import 'core/data/services/event_tracker.dart';
 import 'core/data/services/playback_position_cache.dart';
 import 'core/data/services/playback_session.dart';
+import 'core/data/services/reward_controller.dart';
+import 'core/data/services/unlocked_episode_registry.dart';
 import 'core/data/services/video_player_port.dart';
 import 'core/data/services/wallet_controller.dart';
 import 'core/navigation/app_route_observer.dart';
@@ -87,6 +93,7 @@ class LumaDramaApp extends StatefulWidget {
     this.storeRepository,
     this.searchRepository,
     this.playlistRepository,
+    this.rewardRepository,
     this.haptics = const FlutterHaptics(),
   });
 
@@ -108,6 +115,7 @@ class LumaDramaApp extends StatefulWidget {
   final StoreRepository? storeRepository;
   final SearchRepository? searchRepository;
   final PlaylistRepository? playlistRepository;
+  final RewardRepository? rewardRepository;
   final Haptics haptics;
 
   @override
@@ -176,6 +184,13 @@ class _LumaDramaAppState extends State<LumaDramaApp> {
     _commerceRepository,
   );
 
+  late final RewardRepository _rewardRepository =
+      widget.rewardRepository ?? HttpRewardRepository(RewardApi(_apiClient));
+
+  late final RewardController _rewardController = RewardController(
+    _rewardRepository,
+  );
+
   late final SearchRepository _searchRepository =
       widget.searchRepository ?? HttpSearchRepository(CatalogApi(_apiClient));
 
@@ -207,12 +222,22 @@ class _LumaDramaAppState extends State<LumaDramaApp> {
 
   late final LocaleController _localeController = LocaleController();
 
+  /// 后台下发的启动配置（登录页背景等）；拉不到就用本地默认。
+  late final AppConfigController _appConfigController = AppConfigController(
+    ConfigApi(_apiClient),
+  );
+
+  /// 登录期内共享的「已解锁收费集」：播放页进出、feed 与全屏切换都要沿用。
+  late final UnlockedEpisodeRegistry _unlockedEpisodes =
+      UnlockedEpisodeRegistry();
+
   @override
   void initState() {
     super.initState();
     // 恢复本地令牌与设备号；未登录也能正常浏览，不阻塞首屏
     _auth.load();
     unawaited(_localeController.load());
+    unawaited(_appConfigController.load());
     // 登录/登出时同步收藏状态：收藏属于账号，不能跨账号串联
     _auth.addListener(_onAuthChanged);
     unawaited(_favoriteController.load());
@@ -226,6 +251,8 @@ class _LumaDramaAppState extends State<LumaDramaApp> {
     if (_auth.isSignedIn == _wasSignedIn) return;
     _wasSignedIn = _auth.isSignedIn;
     _interactionController.clear();
+    // 解锁结论属于账号：换人登录后不能沿用上一个人的可播判断。
+    _unlockedEpisodes.clear();
     if (_auth.isSignedIn) {
       unawaited(_favoriteController.load());
       unawaited(_walletController.load());
@@ -234,6 +261,7 @@ class _LumaDramaAppState extends State<LumaDramaApp> {
       unawaited(_favoriteController.load());
       _downloadController.reset();
       _walletController.reset();
+      _rewardController.reset();
     }
   }
 
@@ -243,8 +271,10 @@ class _LumaDramaAppState extends State<LumaDramaApp> {
     _favoriteController.dispose();
     _downloadController.dispose();
     _walletController.dispose();
+    _rewardController.dispose();
     _interactionController.dispose();
     _localeController.dispose();
+    _appConfigController.dispose();
     _apiClient.close();
     super.dispose();
   }
@@ -252,7 +282,9 @@ class _LumaDramaAppState extends State<LumaDramaApp> {
   CategoryController _createCategories() {
     final controller = CategoryController(_categoryRepository);
     if (widget.catalogRepository == null) {
-      controller.dramaPageLoader = CategoryApi(_apiClient).dramas;
+      final api = CategoryApi(_apiClient);
+      controller.dramaPageLoader = api.dramas;
+      controller.rankingLoader = api.ranking;
     }
     controller.load();
     return controller;
@@ -271,6 +303,7 @@ class _LumaDramaAppState extends State<LumaDramaApp> {
           Provider<CatalogApi>.value(value: _catalogApi),
         Provider<PlaybackRepository>.value(value: _playback),
         Provider<PlaybackPositionCache>.value(value: _playbackPositionCache),
+        Provider<UnlockedEpisodeRegistry>.value(value: _unlockedEpisodes),
         Provider<WatchHistoryRepository>.value(value: _watchHistory),
         Provider<FavoriteRepository>.value(value: _favorites),
         Provider<CommentRepository>.value(value: _commentRepository),
@@ -294,8 +327,10 @@ class _LumaDramaAppState extends State<LumaDramaApp> {
         ChangeNotifierProvider.value(value: _favoriteController),
         ChangeNotifierProvider.value(value: _downloadController),
         ChangeNotifierProvider.value(value: _walletController),
+        ChangeNotifierProvider.value(value: _rewardController),
         ChangeNotifierProvider.value(value: _interactionController),
         ChangeNotifierProvider.value(value: _localeController),
+        ChangeNotifierProvider.value(value: _appConfigController),
         ChangeNotifierProvider.value(value: _auth),
       ],
       child: Consumer<LocaleController>(

lib/core/config/app_config.dart

@@ -1,165 +1,51 @@
 // Author: fruit.com.cn
 
-import 'dart:io';
+import 'dev_config.dart';
+import 'prod_config.dart';
 
-import 'package:flutter/foundation.dart';
+/// 客户端运行时配置。
-
-/// 客户端与后端约定的运行时配置。
 ///
-/// 接口地址优先级：运行时设置 > `--dart-define=API_BASE_URL=...` > 平台默认值。
+/// 两套环境各一个文件：
-/// 开发机的局域网地址会随网络变化，换网络后改 [devHostBaseUrl] 即可。
+/// - `dev_config.dart`：[DevConfig]（本机联调）
-class AppConfig {
+/// - `prod_config.dart`：[ProdConfig]（生产）
-  const AppConfig._();
+///
-
+/// 切换环境只改下面这一个布尔值，不用传任何构建参数、也不做网络探测。
-  /// 开发调试默认服务地址，当前指向本机局域网 IP。
+abstract final class AppConfig {
+  /// **环境开关**：true 用开发环境，false 用生产环境。
   ///
-  /// 换网络时只改这一行，地址不要带结尾斜杠。
+  /// 打生产包前必须改成 false；release 构建若仍为 true 会在启动时直接报错。
-  static const String devHostBaseUrl = 'http://192.168.31.243:8081';
+  static const bool useDevConfig = true;
 
-  /// 本机后端地址：通过 `adb reverse tcp:8081 tcp:8081` 映射到开发机，
+  /// 当前选中的环境地址。
-  /// 探测可达时 App 直连本机服务；不可达时回落到公网地址。
+  static String get baseUrl =>
-  static const String lanBaseUrl = 'http://127.0.0.1:8081';
+      useDevConfig ? DevConfig.baseUrl : ProdConfig.baseUrl;
-
-  /// 公网地址（远程/移动网络访问时使用）。
-  static const String publicBaseUrl = 'http://39.162.50.99:8081';
-
-  static const String _overrideBaseUrl = String.fromEnvironment('API_BASE_URL');
 
+  /// 调试面板手改的地址（见 `ServerEndpoint`）；为空表示用上面的环境地址。
   static String _runtimeBaseUrl = '';
 
+  /// 启动期异步准备（iOS 无线数据权限弹窗），目录请求前等待它。
   static Future<void>? _ready;
 
-  /// 启动地址探测完成信号；默认已完成，避免影响既有测试与调用方。
+  /// 启动准备完成信号；默认已完成，避免影响既有测试与调用方。
   static Future<void> get ready => _ready ?? Future<void>.value();
   static set ready(Future<void> value) => _ready = value;
 
-  static const Duration _probeTimeout = Duration(seconds: 2);
+  static const Duration requestTimeout = Duration(seconds: 8);
-  static const List<String> _probeCandidates = [
-    lanBaseUrl,
-    devHostBaseUrl,
-    if (devHostBaseUrl != publicBaseUrl) publicBaseUrl,
-  ];
 
-  /// Build-time server URL supplied through `--dart-define=API_BASE_URL`.
+  /// 实际使用的服务地址：运行时手改优先，否则用环境开关选中的地址。
-  static String get compiledBaseUrl => _overrideBaseUrl;
+  static String get apiBaseUrl =>
+      _runtimeBaseUrl.isNotEmpty ? _runtimeBaseUrl : baseUrl;
 
-  /// Existing platform-aware fallback used when no runtime or build override exists.
+  /// 应用一个已经规范化的运行时地址；传 null 表示清除。
-  static String get defaultBaseUrl => _defaultBaseUrl;
-
-  /// Effective server URL, including the debug-only runtime override.
-  static String get apiBaseUrl => _runtimeBaseUrl.isNotEmpty
-      ? _runtimeBaseUrl
-      : (compiledBaseUrl.isNotEmpty ? compiledBaseUrl : defaultBaseUrl);
-
-  static final String _defaultBaseUrl = _runsOnDevMachine
-      ? lanBaseUrl
-      : devHostBaseUrl;
-
-  /// 模拟器、桌面端与开发机同机，环回地址可用；iOS 真机不满足。
-  /// Android 没有等价的探测方式，统一按真机处理（模拟器用
-  /// `--dart-define=API_BASE_URL=http://10.0.2.2:8081` 覆盖）。
-  static final bool _runsOnDevMachine =
-      kIsWeb ||
-      defaultTargetPlatform == TargetPlatform.macOS ||
-      defaultTargetPlatform == TargetPlatform.windows ||
-      defaultTargetPlatform == TargetPlatform.linux ||
-      (defaultTargetPlatform == TargetPlatform.iOS &&
-          Platform.environment.containsKey('SIMULATOR_DEVICE_NAME'));
-
-  /// Applies an already normalized runtime URL. Passing null clears it.
   static void applyRuntimeBaseUrl(String? value) {
     _runtimeBaseUrl = value ?? '';
   }
 
-  /// Clears the in-memory runtime override, mainly for tests and restarts.
+  /// 清除运行时地址，主要给测试与重启流程用。
   static void clearRuntimeBaseUrl() {
     _runtimeBaseUrl = '';
   }
 
-  static const Duration requestTimeout = Duration(seconds: 8);
-
-  /// 按环回、开发机、公网顺序探测，写入首个返回 200 的地址。
-  ///
-  /// 全部不可达时使用平台默认地址，真机保留开发机地址，避免退回公网。
-  static Future<void> probeAndApplyBaseUrl({
-    Future<bool> Function(String baseUrl)? probe,
-    String? fallbackBaseUrl,
-
-    /// 编译期地址测试注入；未传时读取 `API_BASE_URL`。
-    String? compiledOverride,
-  }) async {
-    final compiled = compiledOverride ?? compiledBaseUrl;
-    if (compiled.isNotEmpty) {
-      if (_runtimeBaseUrl.isEmpty) applyRuntimeBaseUrl(compiled);
-      return;
-    }
-    final candidates = <String>[
-      if (_runtimeBaseUrl.isNotEmpty) _runtimeBaseUrl,
-      for (final candidate in _probeCandidates)
-        if (candidate != _runtimeBaseUrl) candidate,
-    ];
-    final results = await Future.wait([
-      for (final candidate in candidates)
-        probe == null
-            ? _probeBaseUrl(candidate)
-            : _runInjectedProbe(candidate, probe),
-    ]);
-    for (var index = 0; index < candidates.length; index++) {
-      final candidate = candidates[index];
-      final result = results[index];
-      if (kDebugMode) {
-        final status = result.ok
-            ? 'ok'
-            : 'fail(${result.reason ?? 'request failed'})';
-        debugPrint('[probe] $candidate -> $status');
-      }
-      if (result.ok) {
-        applyRuntimeBaseUrl(candidate);
-        return;
-      }
-    }
-    applyRuntimeBaseUrl(fallbackBaseUrl ?? defaultBaseUrl);
-  }
-
-  static Future<_ProbeResult> _runInjectedProbe(
-    String baseUrl,
-    Future<bool> Function(String baseUrl) probe,
-  ) async {
-    try {
-      return _ProbeResult(ok: await probe(baseUrl));
-    } catch (error) {
-      return _ProbeResult(ok: false, reason: error.toString());
-    }
-  }
-
-  static Future<_ProbeResult> _probeBaseUrl(String baseUrl) async {
-    final client = HttpClient()..connectionTimeout = _probeTimeout;
-    try {
-      return await _requestCategories(
-        client,
-        Uri.parse('$baseUrl/app/categories'),
-      ).timeout(_probeTimeout);
-    } catch (error) {
-      return _ProbeResult(ok: false, reason: error.toString());
-    } finally {
-      client.close(force: true);
-    }
-  }
-
-  static Future<_ProbeResult> _requestCategories(
-    HttpClient client,
-    Uri uri,
-  ) async {
-    final request = await client.getUrl(uri);
-    final response = await request.close();
-    await response.drain<void>();
-    final ok = response.statusCode == 200;
-    return _ProbeResult(
-      ok: ok,
-      reason: ok ? null : 'HTTP ${response.statusCode}',
-    );
-  }
-
   /// 后端返回的是相对路径（/files/...），这里补上服务地址。
   static String mediaUrl(String path) {
     if (path.isEmpty) return '';
@@ -167,10 +53,3 @@ class AppConfig {
     return '$apiBaseUrl$path';
   }
 }
-
-class _ProbeResult {
-  const _ProbeResult({required this.ok, this.reason});
-
-  final bool ok;
-  final String? reason;
-}

lib/core/config/dev_config.dart

@@ -0,0 +1,10 @@
+// Author: fruit.com.cn
+
+/// 开发环境配置。
+///
+/// 本机联调用：模拟器与桌面端可直接用回环地址，但 iOS/Android 真机必须用
+/// 开发机的局域网 IP（真机上的 127.0.0.1 指向手机自己）。地址不要带结尾斜杠。
+abstract final class DevConfig {
+  /// 开发机后端地址（Mac 当前 Wi-Fi 地址，换网络后需要同步修改）。
+  static const String baseUrl = 'http://192.168.31.120:8081';
+}

lib/core/config/prod_config.dart

@@ -0,0 +1,9 @@
+// Author: fruit.com.cn
+
+/// 生产环境配置。
+///
+/// 发版前确认这里的 [baseUrl]，地址不要带结尾斜杠。
+abstract final class ProdConfig {
+  /// 生产后端地址。
+  static const String baseUrl = 'http://39.162.50.99:8081';
+}

lib/core/config/server_endpoint.dart

@@ -22,16 +22,9 @@ abstract final class ServerEndpoint {
     return value.replaceFirst(RegExp(r'/+$'), '');
   }
 
-  /// Resolves runtime > dart-define > default using normalized valid values.
+  /// 运行时手改优先，其次构建期默认地址；两者都必须先通过规范校验。
-  static String resolve({
+  static String resolve({required String? stored, required String fallback}) {
-    required String? stored,
+    return normalize(stored) ?? normalize(fallback) ?? fallback;
-    required String compiled,
-    required String fallback,
-  }) {
-    return normalize(stored) ??
-        normalize(compiled) ??
-        normalize(fallback) ??
-        fallback;
   }
 
   /// Loads the persisted override before the app creates its ApiClient.
@@ -46,11 +39,7 @@ abstract final class ServerEndpoint {
       final prefs = preferences ?? SharedPreferencesAsync();
       final stored = await prefs.getString(preferenceKey);
       AppConfig.applyRuntimeBaseUrl(
-        resolve(
+        resolve(stored: stored, fallback: AppConfig.baseUrl),
-          stored: stored,
-          compiled: AppConfig.compiledBaseUrl,
-          fallback: AppConfig.defaultBaseUrl,
-        ),
       );
     } catch (_) {
       AppConfig.clearRuntimeBaseUrl();

lib/core/data/models/category_ranking.dart

@@ -0,0 +1,67 @@
+// Author: fruit.com.cn
+
+import 'drama.dart';
+import 'locale_text.dart';
+
+/// 服务端推荐榜快照；顺序和排名均不可在客户端重算。
+class CategoryRanking {
+  const CategoryRanking({
+    required this.id,
+    required this.code,
+    required this.revision,
+    required this.entries,
+    this.locales = const {},
+    this.generatedAt,
+  });
+
+  final String id;
+  final String code;
+  final String revision;
+  final Map<String, String> locales;
+  final DateTime? generatedAt;
+  final List<CategoryRankingEntry> entries;
+
+  /// 解析 `GET /app/categories/{id}/ranking`。
+  factory CategoryRanking.fromJson(Map<String, dynamic> json) {
+    final rawList = json['list'];
+    final entries = rawList is List
+        ? rawList
+              .whereType<Map>()
+              .map(
+                (item) =>
+                    CategoryRankingEntry.fromJson(item.cast<String, dynamic>()),
+              )
+              .toList(growable: false)
+        : const <CategoryRankingEntry>[];
+    return CategoryRanking(
+      id: (json['id'] ?? '').toString(),
+      code: json['code'] as String? ?? '',
+      revision: (json['revision'] ?? '1').toString(),
+      locales: localeMap(json['locales']),
+      generatedAt: DateTime.tryParse(json['generatedAt'] as String? ?? ''),
+      entries: entries,
+    );
+  }
+}
+
+/// 推荐榜中的一部短剧及其服务端排名。
+class CategoryRankingEntry {
+  const CategoryRankingEntry({required this.rank, required this.drama});
+
+  final int rank;
+  final Drama drama;
+
+  factory CategoryRankingEntry.fromJson(Map<String, dynamic> json) {
+    final rawDrama = json['drama'];
+    return CategoryRankingEntry(
+      rank: (json['rank'] as num?)?.toInt() ?? 0,
+      drama: Drama.fromCardJson(
+        rawDrama is Map<String, dynamic>
+            ? rawDrama
+            : rawDrama is Map
+            ? rawDrama.cast<String, dynamic>()
+            : const <String, dynamic>{},
+      ),
+    );
+  }
+}

lib/core/data/models/content_category.dart

@@ -7,10 +7,19 @@ class ContentCategory {
   const ContentCategory({
     required this.id,
     required this.name,
+    this.code = '',
+    this.layoutType = gridLayout,
+    this.revision = '1',
     this.locales = const {},
   });
 
+  static const String gridLayout = 'GRID';
+  static const String rankingLayout = 'RANKING';
+
   final String id;
+  final String code;
+  final String layoutType;
+  final String revision;
 
   /// 中文名称，与 locales 里的 zh 相同。
   final String name;
@@ -20,9 +29,18 @@ class ContentCategory {
   factory ContentCategory.fromJson(Map<String, dynamic> json) {
     final locales = localeMap(json['locales']);
     final name = json['name'] as String? ?? locales['zh'] ?? '';
-    return ContentCategory(id: (json['id'] ?? '').toString(), name: name, locales: locales);
+    return ContentCategory(
+      id: (json['id'] ?? '').toString(),
+      name: name,
+      code: json['code'] as String? ?? '',
+      layoutType: json['layoutType'] as String? ?? gridLayout,
+      revision: (json['revision'] ?? '1').toString(),
+      locales: locales,
+    );
   }
 
+  bool get isRanking => layoutType == rankingLayout;
+
   /// 按界面语言取名称。缺对应语言时回落到中文。
   String localizedName(String languageCode) {
     return localizedText(languageCode, name, locales);

lib/core/data/models/drama.dart

@@ -97,11 +97,13 @@ class Drama {
     required this.title,
     required this.synopsis,
     required this.posterUrl,
+    this.coverLandscape = '',
     this.episodes = const [],
     this.titleLocales = const {},
     this.synopsisLocales = const {},
     this.tag = '',
     this.tagLocales = const {},
+    this.tagCode = '',
     this.tagColor = '',
     this.category = '',
     this.categoryLocales = const {},
@@ -127,8 +129,14 @@ class Drama {
   final Map<String, String> synopsisLocales;
   final String tag;
   final Map<String, String> tagLocales;
+
+  /// 标签语义码（如 `NEW_ARRIVAL`）。文案会随语言变，语义判断只认这个码。
+  final String tagCode;
   final String tagColor;
   final String posterUrl;
+
+  /// 横版封面，用于继续观看横幅等横向展示位；为空时回退竖版 `posterUrl`。
+  final String coverLandscape;
   final List<Episode> episodes;
   final String category;
   final Map<String, String> categoryLocales;
@@ -172,8 +180,10 @@ class Drama {
       synopsisLocales: text.synopsisLocales,
       tag: text.tag,
       tagLocales: text.tagLocales,
+      tagCode: (json['tagCode'] as String? ?? '').trim(),
       tagColor: json['tagColor'] as String? ?? '',
       posterUrl: json['cover'] as String? ?? '',
+      coverLandscape: json['coverLandscape'] as String? ?? '',
       episodes: preview is Map<String, dynamic>
           ? [Episode.fromJson(preview)]
           : const [],
@@ -204,8 +214,10 @@ class Drama {
       synopsisLocales: text.synopsisLocales,
       tag: text.tag,
       tagLocales: text.tagLocales,
+      tagCode: (json['tagCode'] as String? ?? '').trim(),
       tagColor: json['tagColor'] as String? ?? '',
       posterUrl: json['cover'] as String? ?? '',
+      coverLandscape: json['coverLandscape'] as String? ?? '',
       category: text.category,
       categoryLocales: text.categoryLocales,
       types: text.types,
@@ -315,7 +327,10 @@ class _DramaText {
     final category = _firstText(categoryLocales, json['category'], types);
     return _DramaText(
       title: _firstText(titleLocales, json['title']),
-      synopsis: _firstText(synopsisLocales, json['synopsis'] ?? json['description']),
+      synopsis: _firstText(
+        synopsisLocales,
+        json['synopsis'] ?? json['description'],
+      ),
       titleLocales: titleLocales,
       synopsisLocales: synopsisLocales,
       tag: _firstText(tagLocales, json['tag']),
@@ -328,7 +343,11 @@ class _DramaText {
   }
 }
 
-String _firstText(Map<String, String> locales, Object? fallback, [List<Map<String, String>>? types]) {
+String _firstText(
+  Map<String, String> locales,
+  Object? fallback, [
+  List<Map<String, String>>? types,
+]) {
   final chinese = locales['zh'] ?? '';
   if (chinese.isNotEmpty) return chinese;
   if (types != null && types.isNotEmpty) {
@@ -339,7 +358,9 @@ String _firstText(Map<String, String> locales, Object? fallback, [List<Map<Strin
 }
 
 String _genreText(List<Map<String, String>> types, Object? fallback) {
-  final names = types.map((item) => item['zh'] ?? '').where((value) => value.isNotEmpty);
+  final names = types
+      .map((item) => item['zh'] ?? '')
+      .where((value) => value.isNotEmpty);
   final joined = names.join(' / ');
   if (joined.isNotEmpty) return joined;
   return fallback is String ? fallback : '';

lib/core/data/models/locale_text.dart

@@ -7,7 +7,11 @@ Map<String, String> localeMap(Object? raw) {
 }
 
 /// 按当前语言取文案。没有对应语言时用中文，中文也没有时用 fallback。
-String localizedText(String languageCode, String fallback, Map<String, String> locales) {
+String localizedText(
+  String languageCode,
+  String fallback,
+  Map<String, String> locales,
+) {
   final selected = locales[languageCode] ?? '';
   if (selected.isNotEmpty) return selected;
   final chinese = locales['zh'] ?? '';

lib/core/data/models/reward.dart

@@ -0,0 +1,242 @@
+// Author: fruit.com.cn
+
+import 'json_numbers.dart';
+
+/// 奖励中心首屏数据。
+class RewardOverview {
+  const RewardOverview({
+    required this.serverDate,
+    required this.timezone,
+    required this.coinBalance,
+    required this.checkin,
+    this.sections = const [],
+    this.activities = const [],
+  });
+
+  final String serverDate;
+  final String timezone;
+  final int coinBalance;
+  final RewardCheckinState checkin;
+  final List<RewardSection> sections;
+  final List<RewardActivity> activities;
+
+  factory RewardOverview.fromJson(Map<String, dynamic> json) {
+    return RewardOverview(
+      serverDate: json['serverDate'] as String? ?? '',
+      timezone: json['timezone'] as String? ?? '',
+      coinBalance: jsonToInt(json['coinBalance']),
+      checkin: RewardCheckinState.fromJson(_map(json['checkin'])),
+      sections: _maps(json['sections']).map(RewardSection.fromJson).toList(),
+      activities: _maps(
+        json['activities'],
+      ).map(RewardActivity.fromJson).toList(),
+    );
+  }
+}
+
+/// 七日签到状态。
+class RewardCheckinState {
+  const RewardCheckinState({
+    required this.taskId,
+    required this.checkedInToday,
+    required this.streak,
+    required this.currentDay,
+    this.days = const [],
+  });
+
+  final String taskId;
+  final bool checkedInToday;
+  final int streak;
+  final int currentDay;
+  final List<RewardCheckinDay> days;
+
+  factory RewardCheckinState.fromJson(Map<String, dynamic> json) {
+    return RewardCheckinState(
+      taskId: (json['taskId'] ?? '').toString(),
+      checkedInToday: json['checkedInToday'] == true,
+      streak: jsonToInt(json['streak']),
+      currentDay: jsonToInt(json['currentDay']),
+      days: _maps(json['days']).map(RewardCheckinDay.fromJson).toList(),
+    );
+  }
+}
+
+/// 签到周期中的一天。
+class RewardCheckinDay {
+  const RewardCheckinDay({
+    required this.dayIndex,
+    required this.rewardCoin,
+    required this.checked,
+    required this.current,
+  });
+
+  final int dayIndex;
+  final int rewardCoin;
+  final bool checked;
+  final bool current;
+
+  factory RewardCheckinDay.fromJson(Map<String, dynamic> json) {
+    return RewardCheckinDay(
+      dayIndex: jsonToInt(json['dayIndex']),
+      rewardCoin: jsonToInt(json['rewardCoin']),
+      checked: json['checked'] == true,
+      current: json['current'] == true,
+    );
+  }
+}
+
+/// 一组奖励任务。
+class RewardSection {
+  const RewardSection({
+    required this.code,
+    required this.title,
+    this.tasks = const [],
+  });
+
+  final String code;
+  final String title;
+  final List<RewardTask> tasks;
+
+  factory RewardSection.fromJson(Map<String, dynamic> json) {
+    return RewardSection(
+      code: json['code'] as String? ?? '',
+      title: json['title'] as String? ?? '',
+      tasks: _maps(json['tasks']).map(RewardTask.fromJson).toList(),
+    );
+  }
+}
+
+/// 奖励任务卡片。
+class RewardTask {
+  const RewardTask({
+    required this.id,
+    required this.code,
+    required this.type,
+    required this.title,
+    required this.subtitle,
+    required this.ctaText,
+    required this.actionType,
+    required this.actionUrl,
+    required this.progressValue,
+    required this.targetValue,
+    required this.rewardCoin,
+    required this.status,
+    this.iconUrl = '',
+  });
+
+  final String id;
+  final String code;
+  final String type;
+  final String title;
+  final String subtitle;
+  final String ctaText;
+  final String actionType;
+  final String actionUrl;
+  final String iconUrl;
+  final int progressValue;
+  final int targetValue;
+  final int rewardCoin;
+  final String status;
+
+  bool get claimable => status == 'COMPLETED';
+  bool get claimed => status == 'CLAIMED';
+  double get progress =>
+      targetValue <= 0 ? 0 : (progressValue / targetValue).clamp(0.0, 1.0);
+
+  factory RewardTask.fromJson(Map<String, dynamic> json) {
+    return RewardTask(
+      id: (json['id'] ?? '').toString(),
+      code: json['code'] as String? ?? '',
+      type: json['type'] as String? ?? '',
+      title: json['title'] as String? ?? '',
+      subtitle: json['subtitle'] as String? ?? '',
+      ctaText: json['ctaText'] as String? ?? '',
+      actionType: json['actionType'] as String? ?? '',
+      actionUrl: json['actionUrl'] as String? ?? '',
+      iconUrl: json['iconUrl'] as String? ?? '',
+      progressValue: jsonToInt(json['progressValue']),
+      targetValue: jsonToInt(json['targetValue']),
+      rewardCoin: jsonToInt(json['rewardCoin']),
+      status: json['status'] as String? ?? 'IN_PROGRESS',
+    );
+  }
+}
+
+/// 奖励活动展示卡片。
+class RewardActivity {
+  const RewardActivity({
+    required this.id,
+    required this.code,
+    required this.title,
+    required this.summary,
+    required this.ctaText,
+    required this.actionType,
+    required this.actionUrl,
+    this.coverUrl = '',
+  });
+
+  final String id;
+  final String code;
+  final String title;
+  final String summary;
+  final String ctaText;
+  final String actionType;
+  final String actionUrl;
+  final String coverUrl;
+
+  factory RewardActivity.fromJson(Map<String, dynamic> json) {
+    return RewardActivity(
+      id: (json['id'] ?? '').toString(),
+      code: json['code'] as String? ?? '',
+      title: json['title'] as String? ?? '',
+      summary: json['summary'] as String? ?? '',
+      ctaText: json['ctaText'] as String? ?? '',
+      actionType: json['actionType'] as String? ?? '',
+      actionUrl: json['actionUrl'] as String? ?? '',
+      coverUrl: json['coverUrl'] as String? ?? '',
+    );
+  }
+}
+
+/// 签到或任务领取后的余额变化结果。
+class RewardActionResult {
+  const RewardActionResult({
+    required this.rewardCoin,
+    required this.coinBalance,
+    required this.alreadyCompleted,
+  });
+
+  final int rewardCoin;
+  final int coinBalance;
+  final bool alreadyCompleted;
+
+  factory RewardActionResult.fromCheckin(Map<String, dynamic> json) {
+    return RewardActionResult(
+      rewardCoin: jsonToInt(json['rewardCoin']),
+      coinBalance: jsonToInt(json['coinBalance']),
+      alreadyCompleted: json['alreadyCheckedIn'] == true,
+    );
+  }
+
+  factory RewardActionResult.fromClaim(Map<String, dynamic> json) {
+    return RewardActionResult(
+      rewardCoin: jsonToInt(json['rewardCoin']),
+      coinBalance: jsonToInt(json['coinBalance']),
+      alreadyCompleted: json['alreadyGranted'] == true,
+    );
+  }
+}
+
+Map<String, dynamic> _map(Object? value) {
+  if (value is Map<String, dynamic>) return value;
+  if (value is Map) return value.cast<String, dynamic>();
+  return const {};
+}
+
+List<Map<String, dynamic>> _maps(Object? value) {
+  if (value is! List) return const [];
+  return value
+      .whereType<Map>()
+      .map((item) => item.cast<String, dynamic>())
+      .toList();
+}

lib/core/data/models/watch_progress.dart

@@ -16,6 +16,7 @@ class WatchProgress {
     this.dramaTitle,
     this.titleLocales = const {},
     this.dramaCover,
+    this.dramaCoverLandscape,
     this.episodeNumber,
     this.totalEpisodes,
     this.finished = false,
@@ -29,6 +30,9 @@ class WatchProgress {
   final String? dramaTitle;
   final Map<String, String> titleLocales;
   final String? dramaCover;
+
+  /// 横版封面，用于继续观看横幅等横向位；为空时回退 [dramaCover]。
+  final String? dramaCoverLandscape;
   final int? episodeNumber;
   final int? totalEpisodes;
   final Duration position;
@@ -60,6 +64,7 @@ class WatchProgress {
       dramaTitle: json['dramaTitle']?.toString(),
       titleLocales: localeMap(json['titleLocales']),
       dramaCover: json['dramaCover']?.toString(),
+      dramaCoverLandscape: json['dramaCoverLandscape']?.toString(),
       episodeNumber: json['episodeNumber'] == null
           ? null
           : jsonToInt(json['episodeNumber']),
@@ -83,6 +88,7 @@ class WatchProgress {
     if (dramaTitle != null) 'dramaTitle': dramaTitle,
     if (titleLocales.isNotEmpty) 'titleLocales': titleLocales,
     if (dramaCover != null) 'dramaCover': dramaCover,
+    if (dramaCoverLandscape != null) 'dramaCoverLandscape': dramaCoverLandscape,
     if (episodeNumber != null) 'episodeNumber': episodeNumber,
     if (totalEpisodes != null) 'totalEpisodes': totalEpisodes,
     'positionMs': position.inMilliseconds,

lib/core/data/models/watch_record.dart

@@ -46,6 +46,14 @@ class WatchRecord {
     return pageCover.isNotEmpty ? pageCover : drama?.posterUrl ?? '';
   }
 
+  /// 横向展示位（继续观看横幅）优先用横版封面，缺省回退竖版。
+  String get displayLandscapeCover {
+    final pageLandscape = progress.dramaCoverLandscape?.trim() ?? '';
+    if (pageLandscape.isNotEmpty) return pageLandscape;
+    final landscape = drama?.coverLandscape.trim() ?? '';
+    return landscape.isNotEmpty ? landscape : displayCover;
+  }
+
   /// 分页接口已带展示字段时无需等待详情加载。
   bool get hasDisplayMetadata =>
       displayTitle.isNotEmpty ||

lib/core/data/remote/account_api.dart

@@ -4,6 +4,7 @@ import '../models/account_device.dart';
 import '../models/account_export.dart';
 import '../models/account_profile.dart';
 import 'api_client.dart';
+import 'response_decoders.dart';
 
 /// 个人中心接口：`/app/me*`。
 class AccountApi {
@@ -23,11 +24,9 @@ class AccountApi {
 
   Future<List<AccountDevice>> devices() async {
     final data = await _client.get('/app/me/devices');
-    if (data is! List) return const [];
+    return ResponseDecoders.asMapList(
-    return [
+      data,
-      for (final item in data)
+    ).map(AccountDevice.fromJson).toList();
-        if (item is Map) AccountDevice.fromJson(item.cast<String, dynamic>()),
-    ];
   }
 
   Future<AccountExport> export() async {
@@ -47,6 +46,7 @@ class AccountApi {
     await _client.post('/app/me/deactivate/cancel');
   }
 
+  /// 个人资料允许缺失：后端未返回对象时按空对象解析，页面用默认值兜底。
   Map<String, dynamic> _map(Object? data) =>
-      data is Map ? data.cast<String, dynamic>() : const {};
+      ResponseDecoders.tryMap(data) ?? const {};
 }

lib/core/data/remote/auth_api.dart

@@ -125,6 +125,29 @@ class AuthApi {
     return AuthSession.fromJson((data as Map).cast<String, dynamic>());
   }
 
+  /// Google 登录：把客户端拿到的 idToken 交给后端校验并换发令牌。
+  ///
+  /// 账号按 Google 返回的邮箱归并：邮箱已存在则直接登入，不存在则自动建号。
+  Future<AuthSession> googleLogin({
+    required String idToken,
+    required String deviceId,
+    String platform = '',
+    String osVersion = '',
+    String appVersion = '',
+  }) async {
+    final data = await _client.post(
+      '/app/auth/google',
+      body: {
+        'idToken': idToken,
+        'deviceId': deviceId,
+        'platform': platform,
+        'osVersion': osVersion,
+        'appVersion': appVersion,
+      },
+    );
+    return AuthSession.fromJson((data as Map).cast<String, dynamic>());
+  }
+
   Future<AuthSession> refresh(
     String refreshToken, {
     String platform = '',

lib/core/data/remote/catalog_api.dart

@@ -6,6 +6,7 @@ import '../models/page_result.dart';
 import '../models/playlist_detail.dart';
 import '../models/search_result.dart';
 import 'api_client.dart';
+import 'response_decoders.dart';
 
 /// 客户端目录接口，对应后端 `/app/**`。
 class CatalogApi {
@@ -14,11 +15,15 @@ class CatalogApi {
   final ApiClient _client;
 
   Future<HomeFeed> homeFeed() async {
-    return HomeFeed.fromJson(_asMap(await _client.get('/app/home/feed')));
+    return HomeFeed.fromJson(
+      ResponseDecoders.asMap(await _client.get('/app/home/feed')),
+    );
   }
 
   Future<HomeFeed> discoverFeed() async {
-    return HomeFeed.fromJson(_asMap(await _client.get('/app/discover/feed')));
+    return HomeFeed.fromJson(
+      ResponseDecoders.asMap(await _client.get('/app/discover/feed')),
+    );
   }
 
   /// 推荐流；types/categoryId 为空表示不过滤，cursor 为上一页末条。
@@ -29,7 +34,7 @@ class CatalogApi {
     int size = 10,
   }) async {
     return FeedPage.fromJson(
-      _asMap(
+      ResponseDecoders.asMap(
         await _client.get(
           '/app/feed',
           query: {
@@ -58,7 +63,7 @@ class CatalogApi {
         'pageSize': '$pageSize',
       },
     );
-    return SearchResult.fromJson(_asMap(data));
+    return SearchResult.fromJson(ResponseDecoders.asMap(data));
   }
 
   static const int playlistPageSize = 10;
@@ -86,7 +91,7 @@ class CatalogApi {
     int pageSize = playlistDramaPageSize,
   }) async {
     return PlaylistDetail.fromJson(
-      _asMap(
+      ResponseDecoders.asMap(
         await _client.get(
           '/app/playlists/$id',
           query: {
@@ -138,20 +143,13 @@ class CatalogApi {
 
   Future<Drama> dramaDetail(String dramaId) async {
     return Drama.fromDetailJson(
-      _asMap(await _client.get('/app/dramas/$dramaId')),
+      ResponseDecoders.asMap(await _client.get('/app/dramas/$dramaId')),
     );
   }
 
   List<ContentCategory> _categories(Object? data) {
-    if (data is! List) return const [];
+    return ResponseDecoders.asMapList(
-    return [
+      data,
-      for (final item in data)
+    ).map(ContentCategory.fromJson).toList();
-        if (item is Map<String, dynamic>) ContentCategory.fromJson(item),
-    ];
-  }
-
-  Map<String, dynamic> _asMap(Object? data) {
-    if (data is Map<String, dynamic>) return data;
-    throw const ApiException(-1, '返回数据格式异常');
   }
 }

lib/core/data/remote/category_api.dart

@@ -1,9 +1,11 @@
 // Author: fruit.com.cn
 
 import '../models/content_category.dart';
+import '../models/category_ranking.dart';
 import '../models/drama.dart';
 import '../models/page_result.dart';
 import 'api_client.dart';
+import 'response_decoders.dart';
 
 /// 内容分类接口，对应契约 `GET /app/categories`。
 class CategoryApi {
@@ -16,11 +18,9 @@ class CategoryApi {
   /// 拉取已启用分类，id 全程按字符串解析。
   Future<List<ContentCategory>> list() async {
     final data = await _client.get('/app/categories');
-    if (data is! List) return const [];
+    return ResponseDecoders.asMapList(
-    return [
+      data,
-      for (final item in data)
+    ).map(ContentCategory.fromJson).toList();
-        if (item is Map<String, dynamic>) ContentCategory.fromJson(item),
-    ];
   }
 
   /// 分类下已上线短剧，pageIndex 从 1 开始。
@@ -31,11 +31,14 @@ class CategoryApi {
   }) async {
     final data = await _client.get(
       '/app/categories/$categoryId/dramas',
-      query: {
+      query: {'pageIndex': '$pageIndex', 'pageSize': '$pageSize'},
-        'pageIndex': '$pageIndex',
-        'pageSize': '$pageSize',
-      },
     );
     return PageResult.parse(data, Drama.fromCardJson);
   }
+
+  /// 推荐榜快照，服务端已确定内容顺序和连续排名。
+  Future<CategoryRanking> ranking(String categoryId) async {
+    final data = await _client.get('/app/categories/$categoryId/ranking');
+    return CategoryRanking.fromJson(ResponseDecoders.asMap(data));
+  }
 }

lib/core/data/remote/commerce_api.dart

@@ -4,6 +4,7 @@ import '../models/order.dart';
 import '../models/product.dart';
 import '../models/wallet.dart';
 import 'api_client.dart';
+import 'response_decoders.dart';
 
 /// 金币与解锁接口，对应契约 §1.8。
 class CommerceApi {
@@ -13,8 +14,7 @@ class CommerceApi {
 
   Future<WalletSnapshot> wallet() async {
     final data = await _client.get('/app/wallet');
-    if (data is Map<String, dynamic>) return WalletSnapshot.fromJson(data);
+    return WalletSnapshot.fromJson(ResponseDecoders.asMap(data));
-    throw const ApiException(-1, '返回数据格式异常');
   }
 
   /// 上架商品列表；`type` 传 `COIN_PACK` 或 `VIP`。
@@ -23,13 +23,9 @@ class CommerceApi {
       '/app/products',
       query: type == null ? null : {'type': type},
     );
-    if (data is List) {
+    return ResponseDecoders.requiredMapList(
-      return data
+      data,
-          .whereType<Map<String, dynamic>>()
+    ).map(AppProduct.fromJson).toList();
-          .map(AppProduct.fromJson)
-          .toList();
-    }
-    throw const ApiException(-1, '返回数据格式异常');
   }
 
   /// 创建充值订单，返回 `CREATED` 状态订单。
@@ -38,13 +34,11 @@ class CommerceApi {
       '/app/orders',
       body: {'productId': productId},
     );
-    if (data is Map<String, dynamic>) return AppOrder.fromJson(data);
+    return AppOrder.fromJson(ResponseDecoders.asMap(data));
-    throw const ApiException(-1, '返回数据格式异常');
   }
 
   Future<UnlockResult> unlock(String episodeId) async {
     final data = await _client.post('/app/episodes/$episodeId/unlock');
-    if (data is Map<String, dynamic>) return UnlockResult.fromJson(data);
+    return UnlockResult.fromJson(ResponseDecoders.asMap(data));
-    throw const ApiException(-1, '返回数据格式异常');
   }
 }

lib/core/data/remote/config_api.dart

@@ -0,0 +1,16 @@
+// Author: fruit.com.cn
+
+import 'api_client.dart';
+
+/// 启动配置：`GET /app/config`（匿名，后台只下发白名单键）。
+class ConfigApi {
+  const ConfigApi(this._client);
+
+  final ApiClient _client;
+
+  /// 白名单配置表；结构异常时返回空表，调用方按本地默认处理。
+  Future<Map<String, dynamic>> appConfig() async {
+    final data = await _client.get('/app/config');
+    return data is Map<String, dynamic> ? data : const <String, dynamic>{};
+  }
+}

lib/core/data/remote/download_api.dart

@@ -3,6 +3,7 @@
 import '../models/download_license.dart';
 import '../models/download_policy.dart';
 import 'api_client.dart';
+import 'response_decoders.dart';
 
 /// 离线下载授权接口，对应契约 §1.6 的全部 8 个接口。
 ///
@@ -15,7 +16,7 @@ class DownloadApi {
   /// 拉取配额和偏好策略。
   Future<DownloadPolicy> policy() async {
     return DownloadPolicy.fromJson(
-      _asMap(await _client.get('/app/downloads/policy')),
+      ResponseDecoders.asMap(await _client.get('/app/downloads/policy')),
     );
   }
 
@@ -30,7 +31,7 @@ class DownloadApi {
   /// 申请下载授权；同集重复申请由服务端保证幂等。
   Future<DownloadLicense> grant(String episodeId, {String? quality}) async {
     return DownloadLicense.fromJson(
-      _asMap(
+      ResponseDecoders.asMap(
         await _client.post(
           '/app/downloads',
           body: {'episodeId': episodeId, 'quality': ?quality},
@@ -42,17 +43,17 @@ class DownloadApi {
   /// 拉取当前设备的授权列表。
   Future<List<DownloadLicense>> list() async {
     final data = await _client.get('/app/downloads');
-    if (data is! List) return const [];
+    return ResponseDecoders.asMapList(
-    return [
+      data,
-      for (final item in data)
+    ).map(DownloadLicense.fromJson).toList();
-        if (item is Map<String, dynamic>) DownloadLicense.fromJson(item),
-    ];
   }
 
   /// 续传前刷新短时效下载地址。
   Future<DownloadLicense> refreshUrl(String episodeId) async {
     return DownloadLicense.fromJson(
-      _asMap(await _client.get('/app/downloads/$episodeId/url')),
+      ResponseDecoders.asMap(
+        await _client.get('/app/downloads/$episodeId/url'),
+      ),
     );
   }
 
@@ -67,7 +68,7 @@ class DownloadApi {
     String? errorMsg,
   }) async {
     return DownloadLicense.fromJson(
-      _asMap(
+      ResponseDecoders.asMap(
         await _client.post(
           '/app/downloads/$episodeId/progress',
           body: {
@@ -93,9 +94,4 @@ class DownloadApi {
     final data = await _client.delete('/app/downloads');
     return data is int ? data : 0;
   }
-
-  Map<String, dynamic> _asMap(Object? data) {
-    if (data is Map<String, dynamic>) return data;
-    throw const ApiException(-1, '');
-  }
 }

lib/core/data/remote/playback_api.dart

@@ -3,6 +3,7 @@
 import '../models/episode_stats.dart';
 import '../models/play_ticket.dart';
 import 'api_client.dart';
+import 'response_decoders.dart';
 
 /// 播放票据接口：`GET /app/episodes/{id}/play`（契约 §1.4）。
 ///
@@ -15,14 +16,12 @@ class PlaybackApi {
 
   Future<PlayTicket> ticket(String episodeId) async {
     final data = await _client.get('/app/episodes/$episodeId/play');
-    if (data is Map<String, dynamic>) return PlayTicket.fromJson(data);
+    return PlayTicket.fromJson(ResponseDecoders.asMap(data));
-    throw const ApiException(-1, '返回数据格式异常');
   }
 
   /// 轻量刷新互动计数：不签发地址，也不占用播放票据缓存。
   Future<EpisodeStats> episodeStats(String episodeId) async {
     final data = await _client.get('/app/episodes/$episodeId/stats');
-    if (data is Map<String, dynamic>) return EpisodeStats.fromJson(data);
+    return EpisodeStats.fromJson(ResponseDecoders.asMap(data));
-    throw const ApiException(-1, '返回数据格式异常');
   }
 }

lib/core/data/remote/response_decoders.dart

@@ -0,0 +1,49 @@
+// Author: fruit.com.cn
+
+import 'api_exception.dart';
+
+/// 接口响应 `data` 字段的统一解析。
+///
+/// 此前每个 `*_api.dart` 各写一份 `is Map` 判断与错误文案，还出现过抛空
+/// message 导致界面显示空白的情况；统一收口到这里，语义只有三种：
+/// 必须为对象、可为空对象、对象数组。
+abstract final class ResponseDecoders {
+  /// 业务失败码：HTTP 成功但 `data` 结构不符合约定。
+  static const int malformedCode = -1;
+
+  /// `data` 结构异常时的提示，可直接展示给用户。
+  static const String malformedMessage = '返回数据格式异常';
+
+  /// 要求 `data` 是对象，否则抛 [ApiException]。
+  static Map<String, dynamic> asMap(Object? data) {
+    final map = tryMap(data);
+    if (map == null) {
+      throw const ApiException(malformedCode, malformedMessage);
+    }
+    return map;
+  }
+
+  /// 允许缺失：`data` 为空或不是对象时返回 null。
+  static Map<String, dynamic>? tryMap(Object? data) {
+    if (data is Map<String, dynamic>) return data;
+    if (data is Map) return data.cast<String, dynamic>();
+    return null;
+  }
+
+  /// 对象数组；不是数组时按空列表处理，避免列表页因结构异常白屏。
+  static List<Map<String, dynamic>> asMapList(Object? data) {
+    if (data is! List) return const [];
+    return data
+        .whereType<Map>()
+        .map((item) => item.cast<String, dynamic>())
+        .toList();
+  }
+
+  /// 对象数组；不是数组时抛 [ApiException]，用于不能静默为空的数据（如商品）。
+  static List<Map<String, dynamic>> requiredMapList(Object? data) {
+    if (data is! List) {
+      throw const ApiException(malformedCode, malformedMessage);
+    }
+    return asMapList(data);
+  }
+}

lib/core/data/remote/reward_api.dart

@@ -0,0 +1,30 @@
+// Author: fruit.com.cn
+
+import '../models/reward.dart';
+import 'api_client.dart';
+import 'response_decoders.dart';
+
+/// 奖励中心接口，对应契约 §1.8.1。
+class RewardApi {
+  const RewardApi(this._client);
+
+  final ApiClient _client;
+
+  Future<RewardOverview> overview(String locale) async {
+    final data = await _client.get(
+      '/app/rewards/overview',
+      query: {'locale': locale},
+    );
+    return RewardOverview.fromJson(ResponseDecoders.asMap(data));
+  }
+
+  Future<RewardActionResult> checkIn() async {
+    final data = await _client.post('/app/rewards/check-in');
+    return RewardActionResult.fromCheckin(ResponseDecoders.asMap(data));
+  }
+
+  Future<RewardActionResult> claim(String taskId) async {
+    final data = await _client.post('/app/rewards/tasks/$taskId/claim');
+    return RewardActionResult.fromClaim(ResponseDecoders.asMap(data));
+  }
+}

lib/core/data/remote/watch_api.dart

@@ -3,6 +3,7 @@
 import '../models/page_result.dart';
 import '../models/watch_progress.dart';
 import 'api_client.dart';
+import 'response_decoders.dart';
 
 /// 观看进度接口：`/app/watch/*`（契约 §1.5）。支持账号或设备身份。
 class WatchApi {
@@ -28,7 +29,8 @@ class WatchApi {
         'source': source,
       },
     );
-    return data is Map<String, dynamic> ? WatchProgress.fromJson(data) : null;
+    final map = ResponseDecoders.tryMap(data);
+    return map == null ? null : WatchProgress.fromJson(map);
   }
 
   /// 某部剧的续看位置；没有记录时后端返回空 data。
@@ -37,7 +39,8 @@ class WatchApi {
       '/app/watch/progress',
       query: {'dramaId': dramaId},
     );
-    return data is Map<String, dynamic> ? WatchProgress.fromJson(data) : null;
+    final map = ResponseDecoders.tryMap(data);
+    return map == null ? null : WatchProgress.fromJson(map);
   }
 
   /// 最近观看分页：`pageIndex`/`pageSize`，解包 `PageResult`。
@@ -49,13 +52,9 @@ class WatchApi {
       '/app/watch/recent',
       query: {'pageIndex': '$pageIndex', 'pageSize': '$pageSize'},
     );
-    if (data is! Map) {
+    final map = ResponseDecoders.tryMap(data);
-      return const PageResult();
+    if (map == null) return const PageResult();
-    }
+    return PageResult.fromJson(map, WatchProgress.fromJson);
-    return PageResult.fromJson(
-      Map<String, dynamic>.from(data),
-      WatchProgress.fromJson,
-    );
   }
 
   /// 删除某部剧的观看记录（记录页清单条用）。

lib/core/data/repositories/reward_repository.dart

@@ -0,0 +1,29 @@
+// Author: fruit.com.cn
+
+import '../models/reward.dart';
+import '../remote/reward_api.dart';
+
+/// 奖励中心数据来源。
+abstract interface class RewardRepository {
+  Future<RewardOverview> fetchOverview(String locale);
+
+  Future<RewardActionResult> checkIn();
+
+  Future<RewardActionResult> claim(String taskId);
+}
+
+/// 奖励中心 HTTP 仓库。
+class HttpRewardRepository implements RewardRepository {
+  const HttpRewardRepository(this._api);
+
+  final RewardApi _api;
+
+  @override
+  Future<RewardOverview> fetchOverview(String locale) => _api.overview(locale);
+
+  @override
+  Future<RewardActionResult> checkIn() => _api.checkIn();
+
+  @override
+  Future<RewardActionResult> claim(String taskId) => _api.claim(taskId);
+}

lib/core/data/services/android_picture_in_picture.dart

@@ -3,7 +3,8 @@
 import 'package:flutter/foundation.dart';
 import 'package:flutter/services.dart';
 
-/// Native Android activity PiP; the Flutter playback session keeps the player.
+/// 原生活动级画中画桥：Android 是 Activity PiP（画面即 Flutter 渲染），
+/// iOS 是影子播放器接力（画面/声音来自原生 AVPlayer，退出时进度回传）。
 class AndroidPictureInPicture {
   AndroidPictureInPicture({MethodChannel? channel})
     : _channel = channel ?? const MethodChannel('com.stormg.lumadrama/pip');
@@ -11,22 +12,147 @@ class AndroidPictureInPicture {
   final MethodChannel _channel;
 
   bool get isPlatformSupported =>
-      !kIsWeb && defaultTargetPlatform == TargetPlatform.android;
+      !kIsWeb &&
+      (defaultTargetPlatform == TargetPlatform.android ||
+          defaultTargetPlatform == TargetPlatform.iOS);
 
-  void setStateListener(ValueChanged<bool>? listener) {
+  void Function(bool active, int finalPositionMs)? _pipChangedListener;
-    _channel.setMethodCallHandler(
+  VoidCallback? _playbackEndedListener;
-      listener == null
+
-          ? null
+  /// PiP 状态回调：iOS 停止时 [finalPositionMs] 为影子最终进度（毫秒）。
-          : (call) async {
+  void setStateListener(void Function(bool active, int finalPositionMs)? listener) {
-              if (call.method == 'onPipChanged') {
+    _pipChangedListener = listener;
-                listener(call.arguments == true);
+    _refreshHandler();
   }
-            },
+
+  /// iOS 画中画内影子播完当前集（Android 不会触发）。
+  void setPlaybackEndedListener(VoidCallback? listener) {
+    _playbackEndedListener = listener;
+    _refreshHandler();
+  }
+
+  void _refreshHandler() {
+    if (_pipChangedListener == null && _playbackEndedListener == null) {
+      _channel.setMethodCallHandler(null);
+      return;
+    }
+    _channel.setMethodCallHandler((call) async {
+      switch (call.method) {
+        case 'pipDebug':
+          debugPrint('pip[native]: ${call.arguments}');
+        case 'onPipChanged':
+          final listener = _pipChangedListener;
+          if (listener == null) return;
+          final args = call.arguments;
+          if (args is Map) {
+            listener(
+              args['active'] == true,
+              (args['positionMs'] as num?)?.toInt() ?? 0,
             );
+          } else {
+            // Android 只回传 bool。
+            listener(args == true, 0);
+          }
+        case 'onPipPlaybackEnded':
+          _playbackEndedListener?.call();
+      }
+    });
   }
 
-  Future<bool> enter() async {
+  /// 进入画中画。Android 忽略片源参数；iOS 用 [url] 与 [positionMs]
+  /// 初始化影子播放器（对齐到当前进度、静音待命）。
+  Future<bool> enter({required String url, required int positionMs}) async {
     if (!isPlatformSupported) return false;
-    return await _channel.invokeMethod<bool>('enter') ?? false;
+    return await _channel.invokeMethod<bool>('enter', {
+          'url': url,
+          'positionMs': positionMs,
+        }) ??
+        false;
+  }
+
+  /// 创建影子播放器但不起播（仅 iOS）：
+  /// 自动小窗待命形态——静音暂停，退后台由 [armAutoEnter] 拉起。
+  Future<void> prepareShadow({
+    required String url,
+    required int positionMs,
+    bool autoEnter = false,
+  }) async {
+    if (defaultTargetPlatform != TargetPlatform.iOS || kIsWeb) return;
+    try {
+      await _channel.invokeMethod<void>('prepareShadow', {
+        'url': url,
+        'positionMs': positionMs,
+        'autoEnter': autoEnter,
+      });
+    } catch (_) {}
+  }
+
+  /// 退后台瞬间把影子对齐到当前进度并静音起播，触发系统自动画中画（仅 iOS）。
+  Future<void> armAutoEnter(int positionMs) async {
+    if (defaultTargetPlatform != TargetPlatform.iOS || kIsWeb) return;
+    try {
+      await _channel.invokeMethod<void>('armAutoEnter', {
+        'positionMs': positionMs,
+      });
+    } catch (_) {}
+  }
+
+  /// 回前台后影子回待命（暂停、静音）（仅 iOS）。
+  Future<void> disarmAutoEnter() async {
+    if (defaultTargetPlatform != TargetPlatform.iOS || kIsWeb) return;
+    try {
+      await _channel.invokeMethod<void>('disarmAutoEnter');
+    } catch (_) {}
+  }
+
+  /// 显示原生还原过渡层（仅 iOS；还原动画开始时原生侧也会自动盖上）。
+  Future<void> showRestoreOverlay() async {
+    if (defaultTargetPlatform != TargetPlatform.iOS || kIsWeb) return;
+    try {
+      await _channel.invokeMethod<void>('showRestoreOverlay');
+    } catch (_) {}
+  }
+
+  /// 淡出原生还原过渡层（仅 iOS；视频首帧确认后调用）。
+  Future<void> hideRestoreOverlay() async {
+    if (defaultTargetPlatform != TargetPlatform.iOS || kIsWeb) return;
+    try {
+      await _channel.invokeMethod<void>('hideRestoreOverlay');
+    } catch (_) {}
+  }
+
+  /// 解除影子静音并起播（仅 iOS 有意义，进入 PiP 后声音交给影子）。
+  Future<void> unmute() async {
+    if (defaultTargetPlatform != TargetPlatform.iOS || kIsWeb) return;
+    try {
+      await _channel.invokeMethod<void>('unmute');
+    } catch (_) {}
+  }
+
+  /// iOS 画中画内换集：影子只换播放项，窗口不中断。
+  Future<void> replaceItem({required String url, required int positionMs}) async {
+    if (defaultTargetPlatform != TargetPlatform.iOS || kIsWeb) return;
+    try {
+      await _channel.invokeMethod<void>('replaceItem', {
+        'url': url,
+        'positionMs': positionMs,
+      });
+    } catch (_) {}
+  }
+
+  /// 请求退出画中画（iOS；触发 onPipChanged(false) 后由 Dart 收尾）。
+  Future<void> stop() async {
+    if (defaultTargetPlatform != TargetPlatform.iOS || kIsWeb) return;
+    try {
+      await _channel.invokeMethod<void>('stop');
+    } catch (_) {}
+  }
+
+  /// 销毁影子播放器（仅 iOS）。
+  Future<void> teardown() async {
+    if (defaultTargetPlatform != TargetPlatform.iOS || kIsWeb) return;
+    try {
+      await _channel.invokeMethod<void>('teardown');
+    } catch (_) {}
   }
 }