huixiang_app/lib/im/im_view/im_page.dart

import 'package:dio/dio.dart';
import 'package:flutter/material.dart';
import 'package:flutter_screenutil/flutter_screenutil.dart';
import 'package:flutter_slidable/flutter_slidable.dart';
import 'package:flutter_smart_dialog/flutter_smart_dialog.dart';
import 'package:huixiang/constant.dart';
import 'package:huixiang/data/base_list_data.dart';
import 'package:huixiang/data/msg_stats.dart';
import 'package:huixiang/generated/l10n.dart';
import 'package:huixiang/im/database/message.dart';
import 'package:huixiang/main.dart';
import 'package:huixiang/retrofit/retrofit_api.dart';
import 'package:huixiang/utils/font_weight.dart';
import 'package:huixiang/utils/shared_preference.dart';
import 'package:huixiang/view_widget/classic_header.dart';
import 'package:huixiang/view_widget/my_footer.dart';
import 'package:huixiang/view_widget/round_button.dart';
import 'package:pull_to_refresh/pull_to_refresh.dart';
import 'package:shared_preferences/shared_preferences.dart';

import '../../data/im_user.dart';
import '../../utils/flutter_utils.dart';
import '../../view_widget/custom_image.dart';
import 'on_chat_message.dart';
import 'on_chat_msg_instance.dart';

class IMPage extends StatefulWidget {
  IMPage(Key key) : super(key: key);

  @override
  State<StatefulWidget> createState() {
    return _IMPage();
  }
}

class _IMPage extends State<IMPage> implements OnChatMessage {
  ApiService? apiService;
  int pageNum = 1;
  List<Message> messages = [];
  Map<String, int> msgNumber = {
    "1": 0,
    "2": 0,
    "3": 0,
    "4": 0,
    "5": 0,
    "6": 0,
  };
  int state = 0;
  List<String> conversationIds = [];
  Map<String, Message> lastMessageMap = {};
  Map<String, int> unreadCountMap = {};
  Map<String, ImUser> contactMap = {};
  int insertIndex = 0;
  late String selfUserId;
  final RefreshController _refreshController = RefreshController();

  @override
  void onMessage(txt) {
    // SmartDialog.showToast("列表 $txt", alignment: Alignment.center);
  }

  @override
  void dispose() {
    super.dispose();
    // OnChatMsgInstance.instance.onChatMessage = null;
    socketClient.removeCallback(socketClient.userId);
  }

  @override
  void initState() {
    super.initState();
    // OnChatMsgInstance.instance.onChatMessage = this;

    initSocketClient();

    apiService = ApiService(Dio(), token: SharedInstance.instance.token, context: context);
    queryMsgStats();
  }

  initSocketClient() async {
    selfUserId = SharedInstance.instance.userId;
    socketClient.addCallback(selfUserId, (Message message) {
      if (conversationIds.contains(message.conversationId)) {
        conversationIds.remove(message.conversationId);
      }
      conversationIds.insert(insertIndex, message.conversationId);
      lastMessageMap[message.conversationId] = message;
      listenerRefresh(message);
    });
    loadMessageList();
  }

  _refresh() {
    pageNum = 1;
    loadMessageList();
    queryMsgStats();
  }

  listenerRefresh(Message message) async {
    await sortConversation(lastMessageMap);

    await queryUnreadCount(conversationIds);

    debugPrint("messages_records : ${message.toJson()}");
    if (contactMap[message.fromId] == null) {
      queryMemberInfo([message.fromId]);
      return;
    }
    refreshState();
  }

  loadMessageList() async {
    messages = await hxDatabase.queryList() ?? [];

    lastMessageMap = messages
        .lGroupBy((p0) => p0.conversationId)
        .mGroupItem(key: (p1) => int.parse(p1.time));

    await queryImUserInfo(
        messages.map((e) => e.toId != selfUserId ? e.toId : e.fromId).toList());

    await sortConversation(lastMessageMap);

    await queryUnreadCount(conversationIds);

    refreshState();
  }

  /// update conversation by time sort
  sortConversation(lastMessageMap) async {
    List<Message> sortMessages = lastMessageMap.values.toList();
    sortMessages
        .sort((a, b) => (num.parse(b.time)).compareTo(num.parse(a.time)));
    conversationIds =
        sortMessages.map((e) => e.conversationId).toSet().toList();
  }

  /// update conversation unreadcount
  queryUnreadCount(conversationIds) async {
    unreadCountMap = await hxDatabase.messageUnreadCount(conversationIds);
    debugPrint("unreadCountMap: $unreadCountMap");
  }

  /// update imuser info by mids
  queryImUserInfo(userIds) async {
    List<ImUser> contacts = (await hxDatabase.queryImUser(userIds)) ?? [];
    if (contacts.isEmpty) {
      await queryMemberInfo(userIds);
      return;
    } else {
      List<String> queryUserIds = userIds
          .where((u) => contacts.where((c) => c.mid == u).isEmpty)
          .toList();
      if (queryUserIds.isNotEmpty) {
        await queryMemberInfo(queryUserIds);
        return;
      }
    }
    contactMap = contacts
        .lGroupBy((p0) => conversationId(p0.mid, selfUserId))
        .mGroupItem();
    List<String> topConversationIds = [], notTopUserIds = [];
    contactMap.forEach((key, value) {
      if (value.isTop == 1) {
        topConversationIds.add(key);
      } else {
        notTopUserIds.add(key);
      }
    });
    insertIndex = topConversationIds.length;
    this.conversationIds = topConversationIds..addAll(notTopUserIds);
  }

  /// update one conversation last message ,and update conversation sort
  void updateLastMessage(String conversationId) async {
    Message? message = await hxDatabase.lastMessage(conversationId);
    if (message != null) {
      lastMessageMap[conversationId] = message;
      await sortConversation(lastMessageMap);
      refreshState();
    }
  }

  void updateUnreadCount() async {
    unreadCountMap = await hxDatabase.messageUnreadCount(conversationIds);
    refreshState();
  }

  refreshState() {
    if (_refreshController.isRefresh) _refreshController.refreshCompleted();
    if (mounted) setState(() {});
  }

  ///批量查询用户信息
  queryMemberInfo(List<String> mids) async {
    if (mids.isEmpty) {
      return;
    }
    BaseListData<ImUser>? baseData = await apiService?.memberInfoByIds({
      "mids": mids,
    }).catchError((error) {
      return BaseListData<ImUser>()..isSuccess = false;
    });
    if (baseData?.isSuccess ?? false) {
      if (baseData!.data?.isNotEmpty ?? false) {
        baseData.data!.forEach((element) async {
          await hxDatabase.insertOrUpdateImUser(element.toJson());
        });
        baseData.data!.forEach((element) {
          if (contactMap[conversationId(element.mid, selfUserId)] == null) {
            contactMap[conversationId(element.mid, selfUserId)] = element;
          }
        });
        refreshState();
      }
    }
  }

  ///App消息 统计各类消息数量
  queryMsgStats() async {
    apiService ??= ApiService(
      Dio(),
      context: context,
      token: SharedInstance.instance.token,
    );
    BaseListData<MsgStats>? baseData = await apiService?.stats().catchError((error) {
      return BaseListData<MsgStats>()..isSuccess = false;
    });
    if (baseData?.isSuccess ?? false) {
      setState(() {
        msgNumber.forEach((key, value) {
          msgNumber[key] = 0;
        });
        baseData!.data!.forEach((element) {
          if (msgNumber.containsKey(element.name)) {
            msgNumber["${element.name}"] = element.number ?? 0;
          }
        });
      });
      _refreshController.loadComplete();
      _refreshController.refreshCompleted();
    }
    SmartDialog.dismiss(status: SmartStatus.loading);
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      backgroundColor: Color(0xFFFFFFFF),
      body: Container(
        decoration: BoxDecoration(
          gradient: LinearGradient(
            begin: Alignment.topCenter,
            end: Alignment.bottomCenter,
            colors: [
              Color(0xFFD9FFDE),
              Color(0xFFD9FFDE),
              Color(0xFFFFFFFF),
              Color(0xFFFFFFFF),
            ],
            stops: [0, 0.2, 0.4, 1],
          ),
        ),
        child: Column(
          children: [
            Container(
              padding: EdgeInsets.only(
                top: MediaQuery.of(context).padding.top + 12.h,
                bottom: 15.h,
                right: 16.w,
                left: 16.w,
              ),
              child: Row(
                mainAxisAlignment: MainAxisAlignment.spaceBetween,
                crossAxisAlignment: CrossAxisAlignment.center,
                children: [
                  Expanded(
                    child: Text(
                      S.of(context).xiaoxi,
                      style: TextStyle(
                        color: Colors.black,
                        fontSize: 18.sp,
                        fontWeight: MyFontWeight.bold,
                      ),
                    ),
                  ),
                  GestureDetector(
                    behavior: HitTestBehavior.opaque,
                    onTap: () {
                      Navigator.of(context).pushNamed('/router/chat_friend_group').then((value) {
                        _refresh();
                      });
                    },
                    child: Container(
                      padding: EdgeInsets.all(12),
                      decoration: BoxDecoration(
                        color: Color(0xFFFFFFFF),
                        borderRadius: BorderRadius.circular(20.r),
                      ),
                      child: Image.asset(
                        "assets/image/friend_grouping.webp",
                        fit: BoxFit.fill,
                        height: 14.h,
                        width: 14.h,
                      ),
                    ),
                  ),
                ],
              ),
            ),
            imPageSearch(),
            Expanded(
              child: SmartRefresher(
                enablePullDown: true,
                enablePullUp: false,
                header: MyHeader(),
                physics: BouncingScrollPhysics(),
                footer: CustomFooter(
                  loadStyle: LoadStyle.ShowWhenLoading,
                  builder: (BuildContext context, LoadStatus? mode) {
                    return (messages.length == 0) ? Container() : MyFooter(mode);
                  },
                ),
                controller: _refreshController,
                onRefresh: _refresh,
                onLoading: () {
                  _refresh();
                },
                child: SingleChildScrollView(
                  physics: BouncingScrollPhysics(),
                  child: Column(
                    children: [
                      GestureDetector(
                        behavior: HitTestBehavior.opaque,
                        onTap: () {
                          Navigator.of(context)
                              .pushNamed('/router/system_notice')
                              .then((value) {
                            setState(() {
                              msgNumber["2"] = 0;
                              msgNumber["3"] = 0;
                            });
                          });
                        },
                        child: messageItem(
                            "assets/image/icon_system_message_new.webp",
                            S.of(context).xitongxiaoxi,
                            ((msgNumber["2"] ?? 0) + (msgNumber["3"] ?? 0))
                                .toString(),
                        ),
                      ),
                      GestureDetector(
                        behavior: HitTestBehavior.opaque,
                        onTap: () {
                          Navigator.of(context).pushNamed(
                              '/router/system_details',
                              arguments: {"msgType": 4}).then((value) {
                            setState(() {
                              msgNumber["4"] = 0;
                            });
                          });
                        },
                        child: messageItem("assets/image/icon_gz.webp",
                            S.of(context).guanzhu, msgNumber["4"].toString()),
                      ),
                      GestureDetector(
                        behavior: HitTestBehavior.opaque,
                        onTap: () {
                          Navigator.of(context).pushNamed(
                              '/router/system_details',
                              arguments: {"msgType": 6}).then((value) {
                            setState(() {
                              msgNumber["6"] = 0;
                            });
                          });
                        },
                        child: messageItem("assets/image/icon_pl.webp",
                            S.of(context).pinglun, msgNumber["6"].toString()),
                      ),
                      GestureDetector(
                        behavior: HitTestBehavior.opaque,
                        onTap: () {
                          Navigator.of(context).pushNamed(
                              '/router/system_details',
                              arguments: {"msgType": 5}).then((value) {
                            setState(() {
                              msgNumber["5"] = 0;
                            });
                          });
                        },
                        child: messageItem("assets/image/icon_z.webp",
                            S.of(context).dianzan, msgNumber["5"].toString()),
                      ),
                      chatList(),
                      SizedBox(height: 100.h)
                    ],
                  ),
                ),
              ),
            ),
          ],
        ),
      ),
    );
  }

  ///搜索
  Widget imPageSearch() {
    return GestureDetector(
      behavior: HitTestBehavior.opaque,
      onTap: () {
        Navigator.of(context).pushNamed('/router/im_search').then((value) {
          _refresh();
        });
      },
      child: Container(
          margin: EdgeInsets.fromLTRB(16.w, 0, 16.w, 8.h),
          padding: EdgeInsets.symmetric(vertical: 10.h),
          decoration: BoxDecoration(
            color: Color(0xFFFDFCFC),
            borderRadius: BorderRadius.circular(4),
          ),
          child: Row(
            children: [
              Padding(
                padding: EdgeInsets.only(left: 15.w, right: 5.w),
                child: Image.asset(
                  "assets/image/icon_search.webp",
                  width: 14.h,
                  height: 14.h,
                  color: Color(0xFF353535),
                ),
              ),
              Text(
                "搜索",
                style: TextStyle(
                  color: Color(0xFFA29E9E),
                  fontSize: 16.sp,
                  fontWeight: MyFontWeight.regular,
                ),
              ),
            ],
          ),
      ),
    );
  }

  ///聊天列表
  Widget chatList() {
    return ListView(
      padding: EdgeInsets.zero,
      shrinkWrap: true,
      physics: NeverScrollableScrollPhysics(),
      children: conversationIds.map((e) {
        int position = conversationIds.indexOf(e);
        return InkWell(
          onTap: () {
            Navigator.of(context).pushNamed(
              '/router/chat_details_page',
              arguments: {
                "toUser": contactMap[conversationIds[position]],
              },
            ).then((value) {
              unreadCountMap[conversationIds[position]] = 0;
              updateLastMessage(conversationIds[position]);
              _refresh();
            });
          },
          child: chatItem(e),
        );
      }).toList(),
    );
  }

  Widget chatItem(conversationId) {
    return Slidable(
      key: ValueKey(conversationId),
      direction: Axis.horizontal,
      closeOnScroll: true,
      endActionPane: ActionPane(
        dragDismissible: true,
        extentRatio: 0.25,
        motion: const ScrollMotion(),
        children: [
          SlidableAction(
            onPressed: (BuildContext context) async {
              await hxDatabase.deleteByUser(conversationId);
              _refresh();
            },
            backgroundColor: Color(0xFFFE4A49),
            foregroundColor: Colors.white,
            autoClose: true,
            label: S.of(context).shanchu,
          ),
        ],
      ),
      child: Container(
        padding: EdgeInsets.only(
          left: 16.w,
          right: 17.w,
          top: 8.h,
          bottom: 8.h,
        ),
        width: MediaQuery.of(context).size.width,
        child: Row(
          children: [
            MImage(
              !contactMap.containsKey(conversationId) ? "" : contactMap[conversationId]?.avatar ?? "",
              isCircle: true,
              height: 54,
              width: 54,
              fit: BoxFit.cover,
              errorSrc: "assets/image/default_1.webp",
              fadeSrc: "assets/image/default_1.webp",
            ),
            SizedBox(
              width: 12.w,
            ),
            Expanded(
              child: Column(
                crossAxisAlignment: CrossAxisAlignment.start,
                children: [
                  Row(
                    children: [
                      Expanded(
                        child: Text(
                          !contactMap.containsKey(conversationId)
                              ? ""
                              : contactMap[conversationId]?.nickname ?? "",
                          // overflow: TextOverflow.fade,
                          maxLines: 1,
                          style: TextStyle(
                            fontSize: 16.sp,
                            color: Color(0xFF060606),
                            fontWeight: MyFontWeight.semi_bold,
                          ),
                        ),
                      ),
                      Text(
                        lastMessageMap[conversationId]?.time != null
                            ? AppUtils.timeFormatter(
                            DateTime.fromMillisecondsSinceEpoch(int.parse(
                                lastMessageMap[conversationId]?.time ?? "")))
                            : "",
                        style: TextStyle(
                          fontSize: 12.sp,
                          color: Color(0xFFA29E9E),
                          fontWeight: MyFontWeight.regular,
                        ),
                      ),
                    ],
                  ),
                  SizedBox(
                    height: 7.h,
                  ),
                  Row(
                    children: [
                      Expanded(
                        child: Text(
                          messageContent(lastMessageMap[conversationId]!),
                          maxLines: 1,
                          overflow: TextOverflow.ellipsis,
                          style: TextStyle(
                            fontSize: 12.sp,
                            color: Color(0xFF353535),
                            fontWeight: MyFontWeight.regular,
                          ),
                        ),
                      ),
                      if (unreadCountMap[conversationId] != null &&
                          unreadCountMap[conversationId]! > 0)
                        Container(
                          width: 16,
                          height: 16,
                          decoration: BoxDecoration(
                            borderRadius: BorderRadius.circular(100),
                            color: Color(0xFFFF441A),
                          ),
                          child: RoundButton(
                            text: "${unreadCountMap[conversationId]}",
                            textColor: Colors.white,
                            fontWeight: MyFontWeight.regular,
                            backgroup: Color(0xFFFF441A),
                            fontSize: 10.sp,
                            radius: 100,
                          ),
                        ),
                    ],
                  ),
                ],
              ),
            ),
          ],
        ),
      ),
    );
  }

  String messageContent(Message message) {
    if (message.msgType == 1) {
      return message.content ?? "";
    } else if (message.msgType == 2) {
      return "【图片】";
    } else if (message.msgType == 3) {
      return "【语音】";
    } else if (message.msgType == 4) {
      return "【视频】";
    } else if (message.msgType == 5) {
      return "【红包】";
    } else if (message.msgType == 6) {
      return "【转账】";
    } else if (message.msgType == 7) {
      return "【位置】";
    } else {
      return "【未知的消息类型】";
    }
  }

  Widget messageItem(img, title, messageNum) {
    return Container(
      padding: EdgeInsets.only(
        top: 8.h,
        bottom: 8.h,
        left: 16.w,
        right: 15.w,
      ),
      child: Column(
        children: [
          Row(
            children: [
              Image.asset(
                img,
                fit: BoxFit.fill,
              ),
              SizedBox(
                width: 12.w,
              ),
              Text(
                title,
                style: TextStyle(
                  fontSize: 14.sp,
                  color: Color(0xFF060606),
                  fontWeight: MyFontWeight.semi_bold,
                ),
              ),
              Spacer(),
              if (messageNum != "0")
                (((double.tryParse(messageNum) ?? 0) < 100)
                    ? Container(
                        width: 16,
                        height: 16,
                        decoration: BoxDecoration(
                          borderRadius: BorderRadius.circular(100),
                          color: Color(0xFFFF441A),
                        ),
                        child: RoundButton(
                          text: messageNum,
                          textColor: Colors.white,
                          fontWeight: MyFontWeight.regular,
                          backgroup: Color(0xFFFF441A),
                          fontSize: 10.sp,
                          radius: 100,
                        ))
                    : Container(
                        padding: EdgeInsets.symmetric(
                            horizontal: 4.w, vertical: 2.h),
                        decoration: BoxDecoration(
                          borderRadius: BorderRadius.circular(100),
                          color: Color(0xFFFF441A),
                        ),
                        child: RoundButton(
                          text: "99+",
                          textColor: Colors.white,
                          fontWeight: MyFontWeight.regular,
                          backgroup: Color(0xFFFF441A),
                          fontSize: 10.sp,
                          radius: 100,
                        ))),
            ],
          ),
        ],
      ),
    );
  }

  ///确认删除弹窗
  showDelDialog(conversationId) {
    showDialog(
      context: context,
      builder: (context) {
        return AlertDialog(
          contentPadding: EdgeInsets.zero, // 移除默认内边距
          content: Container(
            // width: MediaQuery.of(context).size.width - 84,
            height: 130.h,
            decoration: BoxDecoration(
              borderRadius: BorderRadius.circular(4),
            ),
            child: Column(
              mainAxisAlignment: MainAxisAlignment.center,
              crossAxisAlignment: CrossAxisAlignment.center,
              children: [
                Expanded(
                  child: Container(
                    alignment: Alignment.center,
                    child: Text(
                      "删除并清空聊天记录",
                      style: TextStyle(
                        color: Color(0xFF060606),
                        fontSize: 16.sp,
                        fontWeight: MyFontWeight.bold,
                      ),
                    ),
                  ),
                ),
                // Spacer(),
                Container(
                  height: 1.h,
                  width: double.infinity,
                  color: Color(0xFFEDEDED),
                ),
                Row(
                  children: [
                    Expanded(
                        child: GestureDetector(
                            behavior: HitTestBehavior.opaque,
                            onTap: () {
                              Navigator.of(context).pop();
                            },
                            child: Container(
                                child: Text("取消",
                                    textAlign: TextAlign.center,
                                    style: TextStyle(
                                      fontSize: 16.sp,
                                      color: Color(0xFF060606),
                                    ))))),
                    Container(
                      height: 45,
                      width: 1.w,
                      color: Color(0xFFEDEDED),
                    ),
                    Expanded(
                      child: GestureDetector(
                        behavior: HitTestBehavior.opaque,
                        onTap: () async {
                          await hxDatabase.deleteByUser(conversationId);
                          _refresh();
                          Navigator.of(context).pop();
                        },
                        child: Text(
                          "确认",
                          textAlign: TextAlign.center,
                          style: TextStyle(
                            color: Color(0xFFFF370A),
                          ),
                        ),
                      ),
                    ),
                  ],
                )
              ],
            ),
          ),
        );
      },
    );
  }
}