FlutterOSC/lib/pages/TweetsListPage.dart

import 'package:flutter/material.dart';
import 'package:flutter_osc/model/constants.dart';
import 'package:flutter_osc/events/LoginEvent.dart';
import 'package:flutter_osc/util/Utf8Utils.dart';
import '../util/BlackListUtils.dart';
import '../model/api.dart';
import '../util/NetUtils.dart';
import '../pages/TweetDetailPage.dart';
import 'login_page.dart';
import 'dart:convert';
import 'dart:async';
import '../util/DataUtils.dart';

class TweetsListPage extends StatefulWidget {
  @override
  State<StatefulWidget> createState() {
    return TweetsListPageState();
  }
}

class TweetsListPageState extends State<TweetsListPage> {
  List? hotTweetsList;
  List? normalTweetsList;
  TextStyle? authorTextStyle;
  TextStyle? subtitleStyle;
  RegExp regExp1 = RegExp("</.*>");
  RegExp regExp2 = RegExp("<.*>");
  num curPage = 1;
  bool loading = false;
  ScrollController? _controller;
  bool isUserLogin = false;

  @override
  void initState() {
    super.initState();
    DataUtils.isLogin().then((isLogin) {
      setState(() {
        this.isUserLogin = isLogin;
      });
    });
    Constants.eventBus.on().listen((event) {
      setState(() {
        this.isUserLogin = true;
      });
    });
    Constants.eventBus.on().listen((event) {
      setState(() {
        this.isUserLogin = false;
      });
    });
  }

  TweetsListPageState() {
    authorTextStyle =
        TextStyle(fontSize: 15.0, fontWeight: FontWeight.bold);
    subtitleStyle =
        TextStyle(fontSize: 12.0, color: const Color(0xFFB5BDC0));
    _controller = ScrollController();
    _controller!.addListener(() {
      var maxScroll = _controller!.position.maxScrollExtent;
      var pixels = _controller!.position.pixels;
      if (maxScroll == pixels) {
        // load next page
        curPage++;
        getTweetsList(true, false);
      }
    });
  }

  getTweetsList(bool isLoadMore, bool isHot) {
    DataUtils.isLogin().then((isLogin) {
      if (isLogin) {
        DataUtils.getAccessToken().then((token) {
          if (token == null || token.length == 0) {
            return;
          }
          loading = true;
          Map<String, String> params = Map();
          params['access_token'] = token;
          params['page'] = "$curPage";
          if (isHot) {
            params['user'] = "-1";
          } else {
            params['user'] = "0";
          }
          params['pageSize'] = "20";
          params['dataType'] = "json";
          NetUtils.get(Api.TWEETS_LIST, params: params).then((data) {
            Map<String, dynamic>? obj = json.decode(data);
            if (!isLoadMore) {
              // first load
              if (isHot) {
                hotTweetsList = obj!['tweetlist'];
              } else {
                normalTweetsList = obj!['tweetlist'];
              }
            } else {
              // load more
              List list = [];
              list.addAll(normalTweetsList!);
              list.addAll(obj!['tweetlist']);
              normalTweetsList = list;
            }
            filterList(hotTweetsList, true);
            filterList(normalTweetsList, false);
          });
        });
      }
    });
  }

  // 根据黑名单过滤出新的数组
  filterList(List<dynamic>? objList, bool isHot) {
    BlackListUtils.getBlackListIds().then((intList) {
      if (intList != null && intList.isNotEmpty && objList != null) {
        List newList = [];
        for (dynamic item in objList) {
          int? authorId = item['authorid'];
          if (!intList.contains(authorId)) {
            newList.add(item);
          }
        }
        setState(() {
          if (isHot) {
            hotTweetsList = newList;
          } else {
            normalTweetsList = newList;
          }
          loading = false;
        });
      } else {
        // 黑名单为空，直接返回原始数据
        setState(() {
          if (isHot) {
            hotTweetsList = objList;
          } else {
            normalTweetsList = objList;
          }
          loading = false;
        });
      }
    });
  }

  // 去掉文本中的html代码
  String clearHtmlContent(String str) {
    if (str.startsWith("<emoji")) {
      return "[emoji]";
    }
    var s = str.replaceAll(regExp1, "");
    s = s.replaceAll(regExp2, "");
    s = s.replaceAll("\n", "");
    return s;
  }

  Widget getRowWidget(Map<String, dynamic> listItem) {
    var authorRow = Row(
      children: [
        Container(
          width: 35.0,
          height: 35.0,
          decoration: BoxDecoration(
            shape: BoxShape.circle,
            color: Colors.transparent,
            image: DecorationImage(
                image: NetworkImage(listItem['portrait']),
                fit: BoxFit.cover),
            border: Border.all(
              color: Colors.white,
              width: 2.0,
            ),
          ),
        ),
        Padding(
            padding: const EdgeInsets.fromLTRB(6.0, 0.0, 0.0, 0.0),
            child: Text(listItem['author'],
                style: TextStyle(
                  fontSize: 16.0,
                ))),
        Expanded(
          child: Row(
            mainAxisAlignment: MainAxisAlignment.end,
            children: [
              Text(
                '${listItem['commentCount']}',
                style: subtitleStyle,
              ),
              Image.asset(
                './images/ic_comment.png',
                width: 16.0,
                height: 16.0,
              )
            ],
          ),
        )
      ],
    );
    var _body = listItem['body'];
    _body = clearHtmlContent(_body);
    var contentRow = Row(
      children: [
        Expanded(
          child: Text(_body),
        )
      ],
    );
    var timeRow = Row(
      mainAxisAlignment: MainAxisAlignment.end,
      children: [
        Text(
          listItem['pubDate'],
          style: subtitleStyle,
        )
      ],
    );
    var columns = <Widget>[
      Padding(
        padding: const EdgeInsets.fromLTRB(10.0, 10.0, 10.0, 2.0),
        child: authorRow,
      ),
      Padding(
        padding: const EdgeInsets.fromLTRB(52.0, 0.0, 10.0, 0.0),
        child: contentRow,
      ),
    ];
    String? imgSmall = listItem['imgSmall'];
    if (imgSmall != null && imgSmall.length > 0) {
      // 动弹中有图片
      List<String> list = imgSmall.split(",");
      List<String> imgUrlList = <String>[];
      for (String s in list) {
        if (s.startsWith("http")) {
          imgUrlList.add(s);
        } else {
          imgUrlList.add("https://static.oschina.net/uploads/space/" + s);
        }
      }
      List<Widget> imgList = [];
      List<List<Widget>> rows = [];
      num len = imgUrlList.length;
      for (var row = 0; row < getRow(len as int); row++) {
        List<Widget> rowArr = [];
        for (var col = 0; col < 3; col++) {
          num index = row * 3 + col;
          num screenWidth = MediaQuery.of(context).size.width;
          double cellWidth = (screenWidth - 100) / 3;
          if (index < len) {
            rowArr.add(Padding(
              padding: const EdgeInsets.all(2.0),
              child: Image.network(imgUrlList[index as int],
                  width: cellWidth, height: cellWidth),
            ));
          }
        }
        rows.add(rowArr);
      }
      for (var row in rows) {
        imgList.add(Row(
          children: row,
        ));
      }
      columns.add(Padding(
        padding: const EdgeInsets.fromLTRB(52.0, 5.0, 10.0, 0.0),
        child: Column(
          children: imgList,
        ),
      ));
    }
    columns.add(Padding(
      padding: const EdgeInsets.fromLTRB(0.0, 10.0, 10.0, 6.0),
      child: timeRow,
    ));
    return InkWell(
      child: Column(
        children: columns,
      ),
      onTap: () {
        // 跳转到动弹详情
        Navigator.of(context).push(MaterialPageRoute(builder: (ctx) {
          return TweetDetailPage(
            tweetData: listItem,
          );
        }));
      },
      onLongPress: () {
        showDialog(
          context: context,
          builder: (BuildContext ctx) {
            return AlertDialog(
              title: Text('提示'),
              content: Text('要把\"${listItem['author']}\"关进小黑屋吗？'),
              actions: <Widget>[
                  TextButton(
                  child: Text(
                    '取消',
                    style: TextStyle(color: Colors.red),
                  ),
                  onPressed: () {
                    Navigator.of(context).pop();
                  },
                ),
                  TextButton(
                  child: Text(
                    '确定',
                    style: TextStyle(color: Colors.blue),
                  ),
                  onPressed: () {
                    putIntoBlackHouse(listItem);
                  },
                )
              ],
            );
          });
      },
    );
  }

  // 关进小黑屋
  putIntoBlackHouse(item) {
    int? authorId = item['authorid'];
    String portrait = "${item['portrait']}";
    String nickname = "${item['author']}";
    DataUtils.getUserInfo().then((info) {
      if (info != null) {
        int? loginUserId = info.id as int?;
        Map<String, String?> params = Map();
        params['userid'] = '$loginUserId';
        params['authorid'] = '$authorId';
        params['authoravatar'] = portrait;
        params['authorname'] = Utf8Utils.encode(nickname);
        NetUtils.post(Api.ADD_TO_BLACK, params: params).then((data) {
          Navigator.of(context).pop();
          if (data != null) {
            var obj = json.decode(data);
            if (obj['code'] == 0) {
              // 添加到小黑屋成功
              showAddBlackHouseResultDialog("添加到小黑屋成功！");
              BlackListUtils.addBlackId(authorId).then((arg) {
                // 添加之后，重新过滤数据
                filterList(normalTweetsList, false);
                filterList(hotTweetsList, true);
              });
            } else {
              // 添加失败
              var msg = obj['msg'];
              showAddBlackHouseResultDialog("添加到小黑屋失败：$msg");
            }
          }
        }).catchError((e) {
          Navigator.of(context).pop();
          showAddBlackHouseResultDialog("网络请求出错：$e");
        });
      }
    });
  }

  showAddBlackHouseResultDialog(String msg) {
    showDialog(
      context: context,
      builder: (BuildContext ctx) {
        return AlertDialog(
          title: Text('提示'),
          content: Text(msg),
          actions: <Widget>[
              TextButton(
              child: Text(
                '确定',
                style: TextStyle(color: Colors.red),
              ),
              onPressed: () {
                Navigator.of(context).pop();
              },
            )
          ],
        );
      });
  }

  renderHotRow(i) {
    if (i.isOdd) {
      return Divider(
        height: 1.0,
      );
    } else {
      i = i ~/ 2;
      return getRowWidget(hotTweetsList![i]);
    }
  }

  renderNormalRow(i) {
    if (i.isOdd) {
      return Divider(
        height: 1.0,
      );
    } else {
      i = i ~/ 2;
      return getRowWidget(normalTweetsList![i]);
    }
  }

  int getRow(int n) {
    int a = n % 3;
    int b = n ~/ 3;
    if (a != 0) {
      return b + 1;
    }
    return b;
  }

  Future<Null> _pullToRefresh() async {
    curPage = 1;
    getTweetsList(false, false);
    return null;
  }

  Widget getHotListView() {
    if (hotTweetsList == null) {
      getTweetsList(false, true);
      return Center(
        child: CircularProgressIndicator(),
      );
    } else {
      // 热门动弹列表
      return ListView.builder(
        itemCount: hotTweetsList!.length * 2 - 1,
        itemBuilder: (context, i) => renderHotRow(i),
      );
    }
  }

  Widget getNormalListView() {
    if (normalTweetsList == null) {
      getTweetsList(false, false);
      return Center(
        child: CircularProgressIndicator(),
      );
    } else {
      // 普通动弹列表
      return RefreshIndicator(
        child: ListView.builder(
          itemCount: normalTweetsList!.length * 2 - 1,
          itemBuilder: (context, i) => renderNormalRow(i),
          physics: const AlwaysScrollableScrollPhysics(),
          controller: _controller,
        ),
        onRefresh: _pullToRefresh);
    }
  }

  @override
  Widget build(BuildContext context) {
    if (!isUserLogin) {
      return Center(
        child: Column(
          mainAxisAlignment: MainAxisAlignment.center,
          children: [
            Container(
              padding: const EdgeInsets.all(10.0),
              child: Center(
                child: Column(
                  children: [
                    Text("由于OSC的openapi限制"),
                    Text("必须登录后才能获取动弹信息")
                  ],
                ),
              )
            ),
            InkWell(
              child: Container(
                padding: const EdgeInsets.fromLTRB(15.0, 8.0, 15.0, 8.0),
                child: Text("去登录"),
                decoration: BoxDecoration(
                  border: Border.all(color: Colors.black),
                  borderRadius: BorderRadius.all(Radius.circular(5.0))
                ),
              ),
              onTap: () async {
                final result = await Navigator.of(context).push(MaterialPageRoute(builder: (BuildContext context) {
                  return LoginPage();
                }));
                if (result != null && result == "refresh") {
                  // 通知动弹页面刷新
                  Constants.eventBus.fire(LoginEvent());
                }
              },
            ),
          ],
        ),
      );
    }
    return DefaultTabController(
      length: 2,
      child: Scaffold(
        appBar: TabBar(
          tabs: <Widget>[
            Tab(
              text: "动弹列表",
            ),
            Tab(
              text: "热门动弹",
            )
          ],
        ),
        body: TabBarView(
          children: [getNormalListView(), getHotListView()],
        )),
    );
  }
}