app-starlock/lib/main/lockDetail/lockSet/configuringWifi/configuringWifi/configuringWifi_logic.dart

import 'dart:async';
import 'dart:convert';
import 'dart:io';
import 'dart:typed_data';

import 'package:flutter_blue_plus/flutter_blue_plus.dart';
import 'package:get/get.dart';
import 'package:network_info_plus/network_info_plus.dart';
import 'package:permission_handler/permission_handler.dart';
import 'package:star_lock/app_settings/app_settings.dart';
import 'package:star_lock/blue/io_gateway/io_gateway_configuringWifi.dart';
import 'package:star_lock/blue/io_gateway/io_gateway_getStatus.dart';
import 'package:star_lock/login/login/entity/LoginEntity.dart';
import 'package:star_lock/main/lockDetail/lockSet/configuringWifi/configuringWifi/configuringWifiEntity.dart';
import 'package:star_lock/mine/gateway/addGateway/gatewayConfigurationWifi/getGatewayConfiguration_entity.dart';
import 'package:star_lock/mine/gateway/addGateway/selectGateway/getGatewayInfo_model.dart';
import 'package:star_lock/talk/startChart/entity/star_chart_register_node_entity.dart';
import 'package:star_lock/talk/startChart/start_chart_manage.dart';
import 'package:star_lock/tools/baseGetXController.dart';

import '../../../../../blue/blue_manage.dart';
import '../../../../../blue/io_protocol/io_configuringWifi.dart';
import '../../../../../blue/io_reply.dart';
import '../../../../../blue/io_tool/io_tool.dart';
import '../../../../../blue/io_tool/manager_event_bus.dart';
import '../../../../../blue/sender_manage.dart';
import '../../../../../network/api_repository.dart';
import '../../../../../tools/eventBusEventManage.dart';
import '../../../../../tools/storage.dart';
import 'configuringWifi_state.dart';

class ConfiguringWifiLogic extends BaseGetXController {
  final ConfiguringWifiState state = ConfiguringWifiState();

  Future<void> getWifiLockServiceIpAndPort() async {
    final ConfiguringWifiEntity entity =
        await ApiRepository.to.getWifiLockServiceIpAndPort();
    if (entity.errorCode! == 0) {
      state.configuringWifiEntity.value = entity;
    }
  }

  Future<void> updateNetworkInfo({
    required String peerId,
    required String wifiName,
    required String secretKey,
    required String deviceMac,
    required String networkMac,
  }) async {
    final LoginEntity entity = await ApiRepository.to.settingDeviceNetwork(
      deviceType: 2,
      deviceMac: deviceMac,
      wifiName: wifiName,
      networkMac: networkMac,
      secretKey: secretKey,
      peerId: peerId,
    );
    if (entity.errorCode!.codeIsSuccessful) {
      showToast('配网成功'.tr, something: () {
        eventBus
            .fire(PassCurrentLockInformationEvent(state.lockSetInfoData.value));
        Get.close(2);
      });
    }
  }

  // 监听设备返回的数据
  late StreamSubscription<Reply> _replySubscription;

  void _initReplySubscription() {
    _replySubscription =
        EventBusManager().eventBus!.on<Reply>().listen((Reply reply) async {
      // WIFI配网结果
      if (reply is GatewayConfiguringWifiResultReply) {
        _replySenderConfiguringWifiResult(reply);
      }
      if (reply is GatewayGetStatusReply) {
        _replyGatewayGetStatusReply(reply);
      }
    });
  }

  // WIFI配网结果
  Future<void> _replySenderConfiguringWifiResult(Reply reply) async {
    final int status = reply.data[2];
    state.sureBtnState.value = 0;
    switch (status) {
      case 0x00:
        //成功
        cancelBlueConnetctToastTimer();
        dismissEasyLoading();
        final int secretKeyJsonLength = (reply.data[4] << 8) + reply.data[3];

        final List<int> secretKeyList =
            reply.data.sublist(5, 5 + secretKeyJsonLength);
        String result = utf8String(secretKeyList);
        // 解析 JSON 字符串为 Map
        Map<String, dynamic> jsonMap = json.decode(result);

        // 提取 peerId
        String? peerId = jsonMap['peerId'];
        String? wifiName = jsonMap['wifiName'];
        String? secretKey = jsonMap['secretKey'];
        String? deviceMac = jsonMap['deviceMac'];
        String? networkMac = jsonMap['networkMac'];

        /// 配网成功后,赋值锁的peerId
        StartChartManage().lockPeerId = peerId ?? '';

        // 保存到缓存
        await Storage.saveLockNetWorkInfo(jsonMap);
        // 上报服务器
        updateNetworkInfo(
            peerId: peerId ?? '',
            wifiName: wifiName ?? '',
            secretKey: secretKey ?? '',
            deviceMac: deviceMac ?? '',
            networkMac: networkMac ?? '');
        break;
      default:
        //失败
        dismissEasyLoading();
        cancelBlueConnetctToastTimer();
        showToast('配网失败'.tr);
        break;
    }
  }

// 辅助函数：美化 JSON 输出
  String prettyPrintJson(String jsonString) {
    var jsonObject = json.decode(jsonString);
    return JsonEncoder.withIndent('  ').convert(jsonObject);
  }

  // 点击配置wifi
  Future<void> senderConfiguringWifiAction() async {
    if (state.wifiNameController.text.isEmpty) {
      showToast('请输入wifi名称'.tr);
      return;
    }

    if (state.wifiPWDController.text.isEmpty) {
      showToast('请输入WiFi密码'.tr);
      return;
    }
    if (state.sureBtnState.value == 1) {
      return;
    }
    state.sureBtnState.value = 1;

    showEasyLoading();
    showBlueConnetctToastTimer(action: () {
      dismissEasyLoading();
      state.sureBtnState.value = 0;
    });

    final GetGatewayConfigurationEntity entity =
        await ApiRepository.to.getGatewayConfiguration(timeout: 60);
    if (entity.errorCode!.codeIsSuccessful) {
      state.getGatewayConfigurationStr = entity.data ?? '';
    }

    // 判断是否登录账户
    final loginData = await Storage.getLoginData();

    // 获取app用户的peerId
    String appPeerId = loginData?.starchart?.starchartId ?? '';
    // 如果已有值，则追加
    if (state.getGatewayConfigurationStr.isNotEmpty) {
      // 解析 JSON 字符串为 Map
      Map<String, dynamic> jsonMap =
          json.decode(state.getGatewayConfigurationStr);

      // 移除指定的键
      jsonMap.remove("starCloudUrl");
      jsonMap.remove("starLockPeerId");

      // 追加新的键值对
      jsonMap['userPeerld'] = appPeerId;

      // 将 Map 转换回 JSON 字符串
      state.getGatewayConfigurationStr =
          json.encode(jsonMap).replaceAll(',', ',\n');

      // 确保格式化输出
      state.getGatewayConfigurationStr =
          prettyPrintJson(state.getGatewayConfigurationStr);
    } else {
      // 如果为空，则直接赋值
      state.getGatewayConfigurationStr = "{\"userPeerld\": \"$appPeerId\"}";
    }
    BlueManage().blueSendData(BlueManage().connectDeviceName,
        (BluetoothConnectionState connectionState) async {
      if (connectionState == BluetoothConnectionState.connected) {
        IoSenderManage.gatewayConfiguringWifiCommand(
          ssid: state.wifiNameController.text,
          password: state.wifiPWDController.text,
          gatewayConfigurationStr: state.getGatewayConfigurationStr,
        );
      } else if (connectionState == BluetoothConnectionState.disconnected) {
        dismissEasyLoading();
        cancelBlueConnetctToastTimer();
        state.sureBtnState.value = 0;
        if (state.ifCurrentScreen.value == true) {
          showBlueConnetctToast();
        }
      }
    }, isAddEquipment: true);
  }

  // 获取设备状态
  Future<void> getDevicesStatusAction() async {
    showEasyLoading();
    showBlueConnetctToastTimer(action: () {
      dismissEasyLoading();
    });
    BlueManage().blueSendData(BlueManage().connectDeviceName,
        (BluetoothConnectionState connectionState) async {
      if (connectionState == BluetoothConnectionState.connected) {
        IoSenderManage.gatewayGetStatusCommand(
          lockID: BlueManage().connectDeviceName,
          userID: await Storage.getUid(),
        );
      } else if (connectionState == BluetoothConnectionState.disconnected) {
        dismissEasyLoading();
        cancelBlueConnetctToastTimer();
        if (state.ifCurrentScreen.value == true) {
          showBlueConnetctToast();
        }
      }
    }, isAddEquipment: true);
  }

  final NetworkInfo _networkInfo = NetworkInfo();

  Future<String> getWifiName() async {
    String ssid = '';
    ssid = (await _networkInfo.getWifiName())!;
    ssid = ssid ?? '';
    ssid = ssid.replaceAll(r'"', '');
    return ssid ?? '';
  }

  ///定位权限
  Future<bool> checkLocationPermission() async {
    final PermissionStatus value = await locationPermission();
    final bool allow = value != PermissionStatus.permanentlyDenied &&
        value != PermissionStatus.denied;
    return allow;
  }

  Future<PermissionStatus> locationPermission() async =>
      Permission.location.request();

  @override
  void onReady() {
    super.onReady();

    if (state.wifiName.value.isEmpty) {
      getWifiName().then((String value) {
        state.wifiNameController.text = value;
      });
    }

    getWifiLockServiceIpAndPort();
    _initReplySubscription();
    getDevicesStatusAction();
  }

  @override
  void onInit() {
    super.onInit();
  }

  @override
  void onClose() {
    _replySubscription.cancel();
    super.onClose();
  }

  void _replyGatewayGetStatusReply(GatewayGetStatusReply reply) {
    final int status = reply.data[2];

    switch (status) {
      case 0x00:
        //成功
        //   state.sureBtnState.value = 0;
        cancelBlueConnetctToastTimer();
        dismissEasyLoading();

        final GetGatewayInfoModel gatewayModel = GetGatewayInfoModel();
        // 网关MAC地址
        int index = 3;
        final List<int> macList = reply.data.sublist(index, index + 20);
        final String macStr = utf8String(macList);
        // lockInfo['mac'] = macStr;
        gatewayModel.mac = macStr;
        index = index + 20;
        AppLog.log('MAC地址 macList:$macList macStr:$macStr');

        // 网关序列号
        final List<int> serialNum = reply.data.sublist(index, index + 20);
        final String serialNumStr = utf8String(serialNum);
        // lockInfo['serialNum'] = serialNumStr;
        gatewayModel.serialNum = serialNumStr;
        index = index + 20;
        AppLog.log('序列号 serialNum:$serialNum serialNumStr:$serialNumStr');

        // 网关版本
        final List<int> gatewayVersion = reply.data.sublist(index, index + 20);
        final String gatewayVersionStr = utf8String(gatewayVersion);
        // lockInfo['gatewayVersion'] = gatewayVersionStr;
        gatewayModel.gatewayVersion = gatewayVersionStr;
        index = index + 20;
        // AppLog.log(
        //     '软件版本 gatewayVersion:$gatewayVersion gatewayVersionStr:$gatewayVersionStr');

        // wifiMac地址
        final List<int> wifiMac = reply.data.sublist(index, index + 20);
        final String wifiMacStr = utf8String(wifiMac);
        // lockInfo['wifiMac'] = wifiMacStr;
        gatewayModel.wifiMac = wifiMacStr;
        index = index + 20;
        AppLog.log('wifiMac地址 wifiMac:$wifiMac wifiMacStr:$wifiMacStr');
        // gatewayModel.wifiMac = '00:00:00:00:00:00';

        break;
      default:
        //失败
        dismissEasyLoading();
        showToast('配网失败'.tr);
        break;
    }
  }
}