import 'dart:convert';

import 'package:EasyDartModule/EasyDartModule.dart';
import 'package:ef/ef.dart';
import 'package:flutter/material.dart';
import 'package:flutterflow_ui/flutterflow_ui.dart';
import 'package:json_annotation/json_annotation.dart';
import 'package:vbvs_app/common/color/ServiceConstant.dart';
import 'package:vbvs_app/common/color/appConstants.dart';
import 'package:vbvs_app/common/color/app_uri_status.dart';
import 'package:vbvs_app/common/util/DailyLogUtils.dart';
import 'package:vbvs_app/common/util/MyUtils.dart';
import 'package:vbvs_app/common/util/requestWithLog.dart';
import 'package:vbvs_app/component/tool/TopSlideNotification.dart';
import 'package:vbvs_app/enum/APPPackageType.dart';
import 'package:vbvs_app/model/api_response.dart';

part 'message_controller.g.dart'; // 由json_serializable自动生成的部分

@JsonSerializable()
class MessageModel {
  int? type = 1; //设备类型 1:体征消息 2.系统消息
  int? body_message_read = 0; //体征消息 0：已读 1：未读
  int? system_message_read = 0; //系统消息  0：已读 1：未读

  MessageModel();

  // 从JSON反序列化时的异常处理

  factory MessageModel.fromJson(Map<String, dynamic> json) {
    try {
      return _$MessageModelFromJson(json);
    } catch (e) {
      // 在实际应用中，应该有更细致的异常处理策略和错误日志
      return MessageModel(); // 或者返回一个带有错误信息的特定DeviceInfoModel实例
    }
  }

  // 序列化为JSON时的异常处理
  Map<String, dynamic> toJson() => _$MessageModelToJson(this);
}

class MessageController extends GetControllerEx<MessageModel> {
  MessageController() {
    attr = GetModel(MessageModel()).obs;
  }

  RxList messageList = [].obs;

  int bodyPage = 1;
  int systemPage = 1;

  Future<void> loadMore(String type) async {
    if (type == "app_vsm") {
      bodyPage++;
      await getMessageList(key: "app_vsm", page: bodyPage, append: true);
    } else {
      systemPage++;
      await getMessageList(key: "app_system", page: systemPage, append: true);
    }
  }

  Future<ApiResponse> getMessageList(
      {String? key, int page = 1, int limit = 20, bool append = false}) async {
    try {
      ApiResponse apiResponse = ApiResponse(code: -1, msg: "请求失败".tr);
      String serviceAddress = ServiceConstant.service_address;
      String serviceName = ServiceConstant.server_service;
      String serviceApi = ServiceConstant.message_list;
      String messageType;
      if (key != null && key.isNotEmpty) {
        messageType = key;
      } else if (model.type == 1) {
        messageType = "app_vsm";
      } else {
        messageType = "app_system";
      }
      String queryUrl =
          "${serviceAddress}${serviceName}${serviceApi}?type=${messageType}&page=$page&limit=$limit";
      String? language = "";
      if (AppConstants().ent_type == APPPackageType.MHT.code) {
        if (mhLanguageController.selectLanguage != null) {
          language = mhLanguageController.selectLanguage.value!.language_code;
        }
      } else {
        if (languageController.selectLanguage != null) {
          language = languageController.selectLanguage.value!.language_code;
        }
      }
      if (language != null && language.isNotEmpty) {
        if (queryUrl.contains("?")) {
          queryUrl += "&lang=$language";
        } else {
          queryUrl += "?lang=$language";
        }
      }
      var response = await EasyDartModule.dio.get(queryUrl);
      if (response != null) {
        var responseData =
            response.data is String ? jsonDecode(response.data) : response.data;
        ApiResponse res =
            ApiResponse.fromJson(responseData, (object) => object);
        MyUtils.formatResponse(res, "请求成功".tr, "请求失败".tr);
        if (res.code == HttpStatusCodes.ok) {
          if (append) {
            messageList.addAll(res.data ?? []);
          } else {
            messageList.assignAll(res.data ?? []);
          }
          updateAll();
          return res;
        }
      } else {
        return ApiResponse(code: -1, msg: "失败".tr);
      }
      return apiResponse;
    } catch (e) {
      EasyDartModule.logger.info("设备请求列表: $e");
      DailyLogUtils.writeLog("设备请求列表: $e");
    }
    return ApiResponse(code: -1, msg: "未知错误".tr); // Default return statement
  }

  //获取消息已读未读
  Future<ApiResponse> getMessageStatus() async {
    try {
      ApiResponse apiResponse = ApiResponse(code: -1, msg: "请求失败".tr);
      // return apiResponse;
      String serviceAddress = ServiceConstant.service_address;
      String serviceName = ServiceConstant.server_service;
      String serviceApi = ServiceConstant.message_read;

      String queryUrl = "${serviceAddress}${serviceName}${serviceApi}";
      String? language = "";
      if (AppConstants().ent_type == APPPackageType.MHT.code) {
        if (mhLanguageController.selectLanguage != null) {
          language = mhLanguageController.selectLanguage.value!.language_code;
        }
      } else {
        if (languageController.selectLanguage != null) {
          language = languageController.selectLanguage.value!.language_code;
        }
      }
      if (language != null && language.isNotEmpty) {
        if (queryUrl.contains("?")) {
          queryUrl += "&lang=$language";
        } else {
          queryUrl += "?lang=$language";
        }
      }
      var response = await EasyDartModule.dio.get(queryUrl);
      if (response != null) {
        var responseData =
            response.data is String ? jsonDecode(response.data) : response.data;
        ApiResponse res =
            ApiResponse.fromJson(responseData, (object) => object);
        MyUtils.formatResponse(res, "请求成功".tr, "请求失败".tr);
        if (res.code == HttpStatusCodes.ok) {
          updateAll();
          List dataList = res.data;

          // 查找 type 为 app_vsm 的项
          var vsmItem = dataList.firstWhere(
            (e) => e['type'] == 'app_vsm',
            orElse: () => null,
          );
          model.body_message_read =
              (vsmItem?['count'] == null || vsmItem?['count'] == 0) ? 0 : 1;

          // 查找 type 为 app_system 的项
          var systemItem = dataList.firstWhere(
            (e) => e['type'] == 'app_system',
            orElse: () => null,
          );
          model.system_message_read =
              (systemItem?['count'] == null || systemItem?['count'] == 0)
                  ? 0
                  : 1;

          updateAll();
          return res;
        }
      } else {
        return ApiResponse(code: -1, msg: "失败".tr);
      }
      return apiResponse;
    } catch (e) {
      EasyDartModule.logger.info("获取消息已读未读: $e");
      DailyLogUtils.writeLog("获取消息已读未读: $e");
    }
    return ApiResponse(code: -1, msg: "未知错误".tr); // Default return statement
  }

  //更新消息已读
  Future<ApiResponse> updateMessageStatus({String? type}) async {
    EasyDartModule.logger.info("更新消息已读状态");
    DailyLogUtils.writeLog("更新消息已读状态");
    try {
      ApiResponse apiResponse = ApiResponse(code: -1, msg: "操作失败".tr);
      String serviceAddress = ServiceConstant.service_address;
      String serviceName = ServiceConstant.server_service;
      String serviceApi = ServiceConstant.message_read;

      // 拼接 URL，添加 type 参数
      String queryUrl = "$serviceAddress$serviceName$serviceApi";
      String? language = "";
      if (AppConstants().ent_type == APPPackageType.MHT.code) {
        if (mhLanguageController.selectLanguage != null) {
          language = mhLanguageController.selectLanguage.value!.language_code;
        }
      } else {
        if (languageController.selectLanguage != null) {
          language = languageController.selectLanguage.value!.language_code;
        }
      }
      if (language != null && language.isNotEmpty) {
        if (queryUrl.contains("?")) {
          queryUrl += "&lang=$language";
        } else {
          queryUrl += "?lang=$language";
        }
      }
      if (type != null) {
        queryUrl = "$queryUrl&type=$type";
      }
      queryUrl = "$queryUrl&mid=ALL";
      queryUrl = "$queryUrl";
      var response = await EasyDartModule.dio.post(queryUrl);

      if (response != null) {
        var responseData =
            response.data is String ? jsonDecode(response.data) : response.data;
        ApiResponse res =
            ApiResponse.fromJson(responseData, (object) => object);
        MyUtils.formatResponse(res, "操作成功".tr, "操作成功".tr);
        return res;
      } else {
        return ApiResponse(code: -1, msg: "失败".tr);
      }
    } catch (e) {
      EasyDartModule.logger.info("更新消息已读状态->$e");
      DailyLogUtils.writeLog("更新消息已读状态->$e");
      return ApiResponse(code: -1, msg: "失败".tr);
    }
  }

  Future<void> updateMessageReadStatus(BuildContext context, String messageType,
      {String? mid, bool all = false}) async {
    final serviceAddress = ServiceConstant.service_address;
    final serviceName = ServiceConstant.server_service;
    final serviceApi = ServiceConstant.message_read;

    // 构建 query 参数
    String queryUrl =
        "$serviceAddress$serviceName$serviceApi?type=$messageType";
    if (all) {
      queryUrl += "&mid=ALL";
    } else if (mid != null && mid.isNotEmpty) {
      queryUrl += "&mid=$mid";
    }

    await requestWithLog(
      logTitle: all ? '更新所有消息为已读' : '更新消息为已读',
      method: MyHttpMethod.post,
      queryUrl: queryUrl,
      onSuccess: (res) {
        if (res.code == HttpStatusCodes.ok) {
          getMessageList(key: messageType);
          getMessageStatus();

          // ✅ 只有在 all 为 true 时才提示
          if (all) {
            TopSlideNotification.show(
              context,
              text: res.msg!,
              textColor: Color(0XFF00C1AA),
            );
          }
        }
      },
      onFailure: (res) {
        TopSlideNotification.show(context,
            text: res.msg!, textColor: Color(0xFFFF7159));
      },
    );
  }
}