Merge branch 'mod-not-login-recommend2'

lib/pages/rcmd/controller.dart

@@ -9,8 +9,8 @@ import 'package:pilipala/utils/storage.dart';
 class RcmdController extends GetxController {
   final ScrollController scrollController = ScrollController();
   int _currentPage = 0;
-  RxList<RecVideoItemAppModel> appVideoList = <RecVideoItemAppModel>[].obs;
-  RxList<RecVideoItemModel> webVideoList = <RecVideoItemModel>[].obs;
+  // RxList<RecVideoItemAppModel> appVideoList = <RecVideoItemAppModel>[].obs;
+  // RxList<RecVideoItemModel> webVideoList = <RecVideoItemModel>[].obs;
   bool isLoadingMore = true;
   OverlayEntry? popupDialog;
   Box recVideo = GStrorage.recVideo;
@@ -18,6 +18,7 @@ class RcmdController extends GetxController {
   RxInt crossAxisCount = 2.obs;
   late bool enableSaveLastData;
   late String defaultRcmdType = 'web';
+  late RxList<dynamic> videoList;
 
   @override
   void onInit() {
@@ -37,85 +38,66 @@ class RcmdController extends GetxController {
         setting.get(SettingBoxKey.enableSaveLastData, defaultValue: false);
     defaultRcmdType =
         setting.get(SettingBoxKey.defaultRcmdType, defaultValue: 'web');
+    if (defaultRcmdType == 'web'){
+      videoList = <RecVideoItemModel>[].obs;
+    } else {
+      videoList = <RecVideoItemAppModel>[].obs;
+    }
   }
 
   // 获取推荐
   Future queryRcmdFeed(type) async {
-    print(defaultRcmdType);
-    if (defaultRcmdType == 'app') {
-      return await queryRcmdFeedApp(type);
-    }
-    if (defaultRcmdType == 'web') {
-      return await queryRcmdFeedWeb(type);
-    }
-  }
-
-  // 获取app端推荐
-  Future queryRcmdFeedApp(type) async {
     if (isLoadingMore == false) {
       return;
     }
     if (type == 'onRefresh') {
       _currentPage = 0;
     }
-    var res = await VideoHttp.rcmdVideoListApp(
-      freshIdx: _currentPage,
-    );
+    late final Map<String,dynamic> res;
+    switch (defaultRcmdType) {
+      case 'app':
+      case 'notLogin':
+        res = await VideoHttp.rcmdVideoListApp(
+          loginStatus: defaultRcmdType != 'notLogin',
+          freshIdx: _currentPage,
+        );
+        break;
+      default: //'web'
+        res = await VideoHttp.rcmdVideoList(
+          freshIdx: _currentPage,
+          ps: 20,
+        );
+    }
     if (res['status']) {
       if (type == 'init') {
-        if (appVideoList.isNotEmpty) {
-          appVideoList.addAll(res['data']);
+        if (videoList.isNotEmpty) {
+          videoList.addAll(res['data']);
         } else {
-          appVideoList.value = res['data'];
+          videoList.value = res['data'];
         }
       } else if (type == 'onRefresh') {
         if (enableSaveLastData) {
-          appVideoList.insertAll(0, res['data']);
+          videoList.insertAll(0, res['data']);
         } else {
-          appVideoList.value = res['data'];
+          videoList.value = res['data'];
         }
       } else if (type == 'onLoad') {
-        appVideoList.addAll(res['data']);
+        videoList.addAll(res['data']);
       }
-      recVideo.put('cacheList', res['data']);
-      _currentPage += 1;
-    }
-    isLoadingMore = false;
-    return res;
-  }
-
-  // 获取web端推荐
-  Future queryRcmdFeedWeb(type) async {
-    if (isLoadingMore == false) {
-      return;
-    }
-    if (type == 'onRefresh') {
-      _currentPage = 0;
-    }
-    var res = await VideoHttp.rcmdVideoList(
-      ps: 20,
-      freshIdx: _currentPage,
-    );
-    if (res['status']) {
-      if (type == 'init') {
-        if (webVideoList.isNotEmpty) {
-          webVideoList.addAll(res['data']);
-        } else {
-          webVideoList.value = res['data'];
-        }
-      } else if (type == 'onRefresh') {
-        if (enableSaveLastData) {
-          webVideoList.insertAll(0, res['data']);
-        } else {
-          webVideoList.value = res['data'];
-        }
-      } else if (type == 'onLoad') {
-        webVideoList.addAll(res['data']);
+      // 目前仅支持app端系列保存缓存
+      if (defaultRcmdType != 'web') {
+        recVideo.put('cacheList', res['data']);
       }
       _currentPage += 1;
+      // 若videoList数量太小，可能会影响翻页，此时再次请求
+      // 为避免请求到的数据太少时还在反复请求，要求本次返回数据大于1条才触发
+      if (res['data'].length > 1 && videoList.length < 10){
+        queryRcmdFeed('onLoad');
+      }
+    } else {
+      Get.snackbar('提示', res['msg']);
     }
     isLoadingMore = false;
-    return res;
   }
 
   // 下拉刷新
@@ -129,7 +111,7 @@ class RcmdController extends GetxController {
     queryRcmdFeed('onLoad');
   }
 
-  // 返回顶部并刷新
+  // 返回顶部
   void animateToTop() async {
     if (scrollController.offset >=
         MediaQuery.of(Get.context!).size.height * 5) {

lib/pages/rcmd/view.dart

@@ -1,5 +1,4 @@
 import 'dart:async';
-import 'dart:io';
 
 import 'package:easy_debounce/easy_throttle.dart';
 import 'package:flutter/material.dart';
@@ -8,7 +7,7 @@ import 'package:get/get.dart';
 import 'package:pilipala/common/constants.dart';
 import 'package:pilipala/common/skeleton/video_card_v.dart';
 import 'package:pilipala/common/widgets/animated_dialog.dart';
-import 'package:pilipala/common/widgets/http_error.dart';
+// import 'package:pilipala/common/widgets/http_error.dart';
 import 'package:pilipala/common/widgets/overlay_pop.dart';
 import 'package:pilipala/common/widgets/video_card_v.dart';
 import 'package:pilipala/pages/home/index.dart';
@@ -26,7 +25,6 @@ class RcmdPage extends StatefulWidget {
 class _RcmdPageState extends State<RcmdPage>
     with AutomaticKeepAliveClientMixin {
   final RcmdController _rcmdController = Get.put(RcmdController());
-  late Future _futureBuilderFuture;
 
   @override
   bool get wantKeepAlive => true;
@@ -34,7 +32,7 @@ class _RcmdPageState extends State<RcmdPage>
   @override
   void initState() {
     super.initState();
-    _futureBuilderFuture = _rcmdController.queryRcmdFeed('init');
+    _rcmdController.queryRcmdFeed('init');
     ScrollController scrollController = _rcmdController.scrollController;
     StreamController<bool> mainStream =
         Get.find<MainController>().bottomBarStream;
@@ -90,57 +88,21 @@ class _RcmdPageState extends State<RcmdPage>
           slivers: [
             SliverPadding(
               padding:
-                  const EdgeInsets.fromLTRB(0, StyleString.safeSpace, 0, 0),
-              sliver: FutureBuilder(
-                future: _futureBuilderFuture,
-                builder: (context, snapshot) {
-                  if (snapshot.connectionState == ConnectionState.done) {
-                    Map data = snapshot.data as Map;
-                    if (data['status']) {
-                      return Platform.isAndroid || Platform.isIOS
-                          ? Obx(
-                              () => contentGrid(
-                                  _rcmdController,
-                                  _rcmdController.defaultRcmdType == 'web'
-                                      ? _rcmdController.webVideoList
-                                      : _rcmdController.appVideoList),
-                            )
-                          : SliverLayoutBuilder(
-                              builder: (context, boxConstraints) {
-                              return Obx(
-                                () => contentGrid(
-                                    _rcmdController,
-                                    _rcmdController.defaultRcmdType == 'web'
-                                        ? _rcmdController.webVideoList
-                                        : _rcmdController.appVideoList),
-                              );
-                            });
-                    } else {
-                      return HttpError(
-                        errMsg: data['msg'],
-                        fn: () {
-                          setState(() {
-                            _futureBuilderFuture =
-                                _rcmdController.queryRcmdFeed('init');
-                          });
-                        },
-                      );
-                    }
-                  } else {
-                    // 缓存数据
-                    // if (_rcmdController.videoList.isNotEmpty) {
-                    //   return contentGrid(
-                    //       _rcmdController, _rcmdController.videoList);
-                    // }
-                    // // 骨架屏
-                    // else {
-                    return contentGrid(_rcmdController, []);
-                    // }
-                  }
-                },
-              ),
+              const EdgeInsets.fromLTRB(0, StyleString.safeSpace, 0, 0),
+              sliver: Obx(() { // 使用Obx来监听数据的变化
+                if (_rcmdController.isLoadingMore && _rcmdController.videoList.isEmpty) {
+                  return contentGrid(_rcmdController, []);
+                  // 如果正在加载并且列表为空，则显示加载指示器
+                  // return const SliverToBoxAdapter(
+                  //   child: Center(child: CircularProgressIndicator()),
+                  // );
+                } else {
+                  // 显示视频列表
+                  return contentGrid(_rcmdController, _rcmdController.videoList);
+                }
+              }),
             ),
-            LoadingMore(ctr: _rcmdController)
+            LoadingMore(ctr: _rcmdController),
           ],
         ),
       ),

lib/pages/setting/extra_setting.dart

@@ -1,9 +1,7 @@
 import 'package:flutter/material.dart';
 import 'package:flutter_smart_dialog/flutter_smart_dialog.dart';
 import 'package:hive/hive.dart';
-import 'package:pilipala/http/member.dart';
 import 'package:pilipala/models/common/dynamics_type.dart';
-import 'package:pilipala/models/common/rcmd_type.dart';
 import 'package:pilipala/models/common/reply_sort_type.dart';
 import 'package:pilipala/pages/setting/widgets/select_dialog.dart';
 import 'package:pilipala/utils/storage.dart';
@@ -20,23 +18,16 @@ class ExtraSetting extends StatefulWidget {
 class _ExtraSettingState extends State<ExtraSetting> {
   Box setting = GStrorage.setting;
   static Box localCache = GStrorage.localCache;
-  late dynamic defaultRcmdType;
   late dynamic defaultReplySort;
   late dynamic defaultDynamicType;
   late dynamic enableSystemProxy;
   late String defaultSystemProxyHost;
   late String defaultSystemProxyPort;
-  Box userInfoCache = GStrorage.userInfo;
-  var userInfo;
   bool userLogin = false;
-  var accessKeyInfo;
 
   @override
   void initState() {
     super.initState();
-    // 首页默认推荐类型
-    defaultRcmdType =
-        setting.get(SettingBoxKey.defaultRcmdType, defaultValue: 'web');
     // 默认优先显示最新评论
     defaultReplySort =
         setting.get(SettingBoxKey.replySortType, defaultValue: 0);
@@ -49,9 +40,6 @@ class _ExtraSettingState extends State<ExtraSetting> {
         localCache.get(LocalCacheKey.systemProxyHost, defaultValue: '');
     defaultSystemProxyPort =
         localCache.get(LocalCacheKey.systemProxyPort, defaultValue: '');
-    userInfo = userInfoCache.get('userInfoCache');
-    userLogin = userInfo != null;
-    accessKeyInfo = localCache.get(LocalCacheKey.accessKey, defaultValue: null);
   }
 
   // 设置代理
@@ -159,12 +147,6 @@ class _ExtraSettingState extends State<ExtraSetting> {
             setKey: SettingBoxKey.enableSearchWord,
             defaultVal: true,
           ),
-          const SetSwitchItem(
-            title: '推荐动态',
-            subTitle: '是否在推荐内容中展示动态',
-            setKey: SettingBoxKey.enableRcmdDynamic,
-            defaultVal: true,
-          ),
           const SetSwitchItem(
             title: '快速收藏',
             subTitle: '点按收藏至默认，长按选择文件夹',
@@ -177,50 +159,6 @@ class _ExtraSettingState extends State<ExtraSetting> {
             setKey: SettingBoxKey.enableWordRe,
             defaultVal: false,
           ),
-          const SetSwitchItem(
-            title: '首页推荐刷新',
-            subTitle: '下拉刷新时保留上次内容',
-            setKey: SettingBoxKey.enableSaveLastData,
-            defaultVal: false,
-          ),
-          ListTile(
-            dense: false,
-            title: Text('首页推荐类型', style: titleStyle),
-            subtitle: Text(
-              '当前使用「$defaultRcmdType端」推荐',
-              style: subTitleStyle,
-            ),
-            onTap: () async {
-              String? result = await showDialog(
-                context: context,
-                builder: (context) {
-                  return SelectDialog<String>(
-                    title: '推荐类型',
-                    value: defaultRcmdType,
-                    values: RcmdType.values.map((e) {
-                      return {'title': e.labels, 'value': e.values};
-                    }).toList(),
-                  );
-                },
-              );
-              if (result != null) {
-                if (result == 'app') {
-                  // app端推荐需要access_key
-                  if (accessKeyInfo == null) {
-                    if (!userLogin) {
-                      SmartDialog.showToast('请先登录');
-                      return;
-                    }
-                    await MemberHttp.cookieToKey();
-                  }
-                }
-                defaultRcmdType = result;
-                setting.put(SettingBoxKey.defaultRcmdType, result);
-                SmartDialog.showToast('下次启动时生效');
-                setState(() {});
-              }
-            },
-          ),
           const SetSwitchItem(
             title: '启用ai总结',
             subTitle: '视频详情页开启ai总结',

lib/pages/setting/recommend_setting.dart

@@ -0,0 +1,260 @@
+import 'package:flutter/material.dart';
+import 'package:flutter_smart_dialog/flutter_smart_dialog.dart';
+import 'package:hive/hive.dart';
+import 'package:pilipala/http/member.dart';
+import 'package:pilipala/models/common/rcmd_type.dart';
+import 'package:pilipala/pages/setting/widgets/select_dialog.dart';
+import 'package:pilipala/utils/recommend_filter.dart';
+import 'package:pilipala/utils/storage.dart';
+
+import 'widgets/switch_item.dart';
+
+class RecommendSetting extends StatefulWidget {
+  const RecommendSetting({super.key});
+
+  @override
+  State<RecommendSetting> createState() => _RecommendSettingState();
+}
+
+class _RecommendSettingState extends State<RecommendSetting> {
+  Box setting = GStrorage.setting;
+  static Box localCache = GStrorage.localCache;
+  late dynamic defaultRcmdType;
+  Box userInfoCache = GStrorage.userInfo;
+  late dynamic userInfo;
+  bool userLogin = false;
+  late dynamic accessKeyInfo;
+  // late int filterUnfollowedRatio;
+  late int minDurationForRcmd;
+  late int minLikeRatioForRecommend;
+
+  @override
+  void initState() {
+    super.initState();
+    // 首页默认推荐类型
+    defaultRcmdType =
+        setting.get(SettingBoxKey.defaultRcmdType, defaultValue: 'web');
+    userInfo = userInfoCache.get('userInfoCache');
+    userLogin = userInfo != null;
+    accessKeyInfo = localCache.get(LocalCacheKey.accessKey, defaultValue: null);
+    // filterUnfollowedRatio = setting
+    //     .get(SettingBoxKey.filterUnfollowedRatio, defaultValue: 0);
+    minDurationForRcmd =
+        setting.get(SettingBoxKey.minDurationForRcmd, defaultValue: 0);
+    minLikeRatioForRecommend =
+        setting.get(SettingBoxKey.minLikeRatioForRecommend, defaultValue: 0);
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    TextStyle titleStyle = Theme.of(context).textTheme.titleMedium!;
+    TextStyle subTitleStyle = Theme.of(context)
+        .textTheme
+        .labelMedium!
+        .copyWith(color: Theme.of(context).colorScheme.outline);
+    return Scaffold(
+      appBar: AppBar(
+        centerTitle: false,
+        titleSpacing: 0,
+        title: Text(
+          '推荐设置',
+          style: Theme.of(context).textTheme.titleMedium,
+        ),
+      ),
+      body: ListView(
+        children: [
+          ListTile(
+            dense: false,
+            title: Text('首页推荐类型', style: titleStyle),
+            subtitle: Text(
+              '当前使用「$defaultRcmdType端」推荐¹',
+              style: subTitleStyle,
+            ),
+            onTap: () async {
+              String? result = await showDialog(
+                context: context,
+                builder: (context) {
+                  return SelectDialog<String>(
+                    title: '推荐类型',
+                    value: defaultRcmdType,
+                    values: RcmdType.values.map((e) {
+                      return {'title': e.labels, 'value': e.values};
+                    }).toList(),
+                  );
+                },
+              );
+              if (result != null) {
+                if (result == 'app') {
+                  // app端推荐需要access_key
+                  if (accessKeyInfo == null) {
+                    if (!userLogin) {
+                      SmartDialog.showToast('请先登录');
+                      return;
+                    }
+                    // 显示一个确认框，告知用户可能会导致账号被风控
+                    SmartDialog.show(
+                        animationType: SmartAnimationType.centerFade_otherSlide,
+                        builder: (context) {
+                          return AlertDialog(
+                            title: const Text('提示'),
+                            content: const Text(
+                                '使用app端推荐需获取access_key，有小概率触发风控导致账号退出（在官方版本app重新登录即可解除），是否继续？'),
+                            actions: [
+                              TextButton(
+                                onPressed: () {
+                                  result = null;
+                                  SmartDialog.dismiss();
+                                },
+                                child: const Text('取消'),
+                              ),
+                              TextButton(
+                                onPressed: () async {
+                                  SmartDialog.dismiss();
+                                  await MemberHttp.cookieToKey();
+                                },
+                                child: const Text('确定'),
+                              ),
+                            ],
+                          );
+                        });
+                  }
+                }
+                if (result != null) {
+                  defaultRcmdType = result;
+                  setting.put(SettingBoxKey.defaultRcmdType, result);
+                  SmartDialog.showToast('下次启动时生效');
+                  setState(() {});
+                }
+              }
+            },
+          ),
+          const SetSwitchItem(
+            title: '推荐动态',
+            subTitle: '是否在推荐内容中展示动态(仅app端)',
+            setKey: SettingBoxKey.enableRcmdDynamic,
+            defaultVal: true,
+          ),
+          const SetSwitchItem(
+            title: '首页推荐刷新',
+            subTitle: '下拉刷新时保留上次内容',
+            setKey: SettingBoxKey.enableSaveLastData,
+            defaultVal: false,
+          ),
+          // 分割线
+          const Divider(height: 1),
+          ListTile(
+            dense: false,
+            title: Text('点赞率过滤', style: titleStyle),
+            subtitle: Text(
+              '过滤掉点赞数/播放量「小于$minLikeRatioForRecommend%」的推荐视频(仅web端)',
+              style: subTitleStyle,
+            ),
+            onTap: () async {
+              int? result = await showDialog(
+                context: context,
+                builder: (context) {
+                  return SelectDialog<int>(
+                      title: '选择点赞率（0即不过滤）',
+                      value: minLikeRatioForRecommend,
+                      values: [0, 1, 2, 3, 4].map((e) {
+                        return {'title': '$e %', 'value': e};
+                      }).toList());
+                },
+              );
+              if (result != null) {
+                minLikeRatioForRecommend = result;
+                setting.put(SettingBoxKey.minLikeRatioForRecommend, result);
+                RecommendFilter.update();
+                setState(() {});
+              }
+            },
+          ),
+          ListTile(
+            dense: false,
+            title: Text('视频时长过滤', style: titleStyle),
+            subtitle: Text(
+              '过滤掉时长「小于$minDurationForRcmd秒」的推荐视频',
+              style: subTitleStyle,
+            ),
+            onTap: () async {
+              int? result = await showDialog(
+                context: context,
+                builder: (context) {
+                  return SelectDialog<int>(
+                      title: '选择时长（0即不过滤）',
+                      value: minDurationForRcmd,
+                      values: [0, 30, 60, 90, 120].map((e) {
+                        return {'title': '$e 秒', 'value': e};
+                      }).toList());
+                },
+              );
+              if (result != null) {
+                minDurationForRcmd = result;
+                setting.put(SettingBoxKey.minDurationForRcmd, result);
+                RecommendFilter.update();
+                setState(() {});
+              }
+            },
+          ),
+          SetSwitchItem(
+            title: '已关注Up豁免推荐过滤',
+            subTitle: '推荐中已关注用户发布的内容不会被过滤',
+            setKey: SettingBoxKey.exemptFilterForFollowed,
+            defaultVal: true,
+            callFn: (_) => {RecommendFilter.update},
+          ),
+          // ListTile(
+          //   dense: false,
+          //   title: Text('按比例过滤未关注Up', style: titleStyle),
+          //   subtitle: Text(
+          //     '滤除推荐中占比「$filterUnfollowedRatio%」的未关注用户发布的内容',
+          //     style: subTitleStyle,
+          //   ),
+          //   onTap: () async {
+          //     int? result = await showDialog(
+          //       context: context,
+          //       builder: (context) {
+          //         return SelectDialog<int>(
+          //             title: '选择滤除比例（0即不过滤）',
+          //             value: filterUnfollowedRatio,
+          //             values: [0, 16, 32, 48, 64].map((e) {
+          //               return {'title': '$e %', 'value': e};
+          //             }).toList());
+          //       },
+          //     );
+          //     if (result != null) {
+          //       filterUnfollowedRatio = result;
+          //       setting.put(
+          //           SettingBoxKey.filterUnfollowedRatio, result);
+          //       RecommendFilter.update();
+          //       setState(() {});
+          //     }
+          //   },
+          // ),
+          SetSwitchItem(
+            title: '过滤器也应用于相关视频',
+            subTitle: '视频详情页的相关视频也进行过滤²',
+            setKey: SettingBoxKey.applyFilterToRelatedVideos,
+            defaultVal: true,
+            callFn: (_) => {RecommendFilter.update},
+          ),
+          ListTile(
+            dense: true,
+            subtitle: Text(
+              '¹ 若默认web端推荐不太符合预期，可尝试切换至app端。\n'
+              '¹ 选择“模拟未登录(notLogin)”，将以空的key请求推荐接口，但播放页仍会携带用户信息，保证账号能正常记录进度、点赞投币等。\n\n'
+              '² 由于接口未提供关注信息，无法豁免相关视频中的已关注Up。\n\n'
+              '* 其它（如热门视频、手动搜索、链接跳转等）均不受过滤器影响。\n'
+              '* 设定较严苛的条件可导致推荐项数锐减或多次请求，请酌情选择。\n'
+              '* 后续可能会增加更多过滤条件，敬请期待。',
+              style: Theme.of(context)
+                  .textTheme
+                  .labelSmall!
+                  .copyWith(color: Theme.of(context).colorScheme.outline.withOpacity(0.7)),
+            ),
+          )
+        ],
+      ),
+    );
+  }
+}

lib/pages/setting/view.dart

@@ -24,6 +24,11 @@ class SettingPage extends StatelessWidget {
             dense: false,
             title: const Text('隐私设置'),
           ),
+          ListTile(
+            onTap: () => Get.toNamed('/recommendSetting'),
+            dense: false,
+            title: const Text('推荐设置'),
+          ),
           ListTile(
             onTap: () => Get.toNamed('/playSetting'),
             dense: false,